taler/exchange
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

try with row locking to avoid rollbacks (in theory, to be verified)

Browse Source
This commit is contained in:
Christian Grothoff 2018-08-09 22:27:43 +02:00
parent 68848aaf5c
commit bce6a80f38
No known key found for this signature in database
GPG Key ID: 939E6BE1E29FC3CC
1 changed files with 15 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/exchangedb/plugin_exchangedb_postgres.c
View File

@ -682,7 +682,8 @@ postgres_prepare (PGconn *db_conn)
",execution_date" ",execution_date"
",sender_account_details" ",sender_account_details"
" FROM reserves_in" " FROM reserves_in"
" WHERE reserve_pub=$1;", " WHERE reserve_pub=$1"
" FOR UPDATE;",
1), 1),
/* Used in #postgres_insert_withdraw_info() to store /* Used in #postgres_insert_withdraw_info() to store
the signature of a blinded coin with the blinded coin's the signature of a blinded coin with the blinded coin's
@ -725,7 +726,8 @@ postgres_prepare (PGconn *db_conn)
" FROM reserves_out" " FROM reserves_out"
" JOIN denominations denom" " JOIN denominations denom"
" USING (denom_pub_hash)" " USING (denom_pub_hash)"
" WHERE h_blind_ev=$1;", " WHERE h_blind_ev=$1"
" FOR UPDATE;",
1), 1),
/* Used during #postgres_get_reserve_history() to /* Used during #postgres_get_reserve_history() to
obtain all of the /reserve/withdraw operations that obtain all of the /reserve/withdraw operations that
@ -747,7 +749,8 @@ postgres_prepare (PGconn *db_conn)
" FROM reserves_out" " FROM reserves_out"
" JOIN denominations denom" " JOIN denominations denom"
" USING (denom_pub_hash)" " USING (denom_pub_hash)"
" WHERE reserve_pub=$1;", " WHERE reserve_pub=$1"
" FOR UPDATE",
1), 1),
/* Used in #postgres_select_reserves_out_above_serial_id() */ /* Used in #postgres_select_reserves_out_above_serial_id() */
GNUNET_PQ_make_prepare ("audit_get_reserves_out_incr", GNUNET_PQ_make_prepare ("audit_get_reserves_out_incr",
@ -1498,7 +1501,8 @@ postgres_prepare (PGconn *db_conn)
" USING (denom_pub_hash)" " USING (denom_pub_hash)"
" JOIN reserves_out ro" " JOIN reserves_out ro"
" USING (h_blind_ev)" " USING (h_blind_ev)"
" WHERE ro.reserve_pub=$1;", " WHERE ro.reserve_pub=$1"
" FOR UPDATE;",
1), 1),
/* Used in #postgres_get_reserve_history() */ /* Used in #postgres_get_reserve_history() */
GNUNET_PQ_make_prepare ("close_by_reserve", GNUNET_PQ_make_prepare ("close_by_reserve",
@ -1513,7 +1517,8 @@ postgres_prepare (PGconn *db_conn)
",receiver_account" ",receiver_account"
",wtid" ",wtid"
" FROM reserves_close" " FROM reserves_close"
" WHERE reserve_pub=$1;", " WHERE reserve_pub=$1"
" FOR UPDATE",
1), 1),
/* Used in #postgres_get_expired_reserves() */ /* Used in #postgres_get_expired_reserves() */
GNUNET_PQ_make_prepare ("get_expired_reserves", GNUNET_PQ_make_prepare ("get_expired_reserves",
@ -6706,7 +6711,7 @@ sum_kyc_events (void *cls,
struct GNUNET_PQ_ResultSpec rs[] = { struct GNUNET_PQ_ResultSpec rs[] = {
TALER_PQ_result_spec_amount ("amount", &tmp), TALER_PQ_result_spec_amount ("amount", &tmp),
GNUNET_PQ_result_spec_end GNUNET_PQ_result_spec_end
}; };
for (unsigned int i = 0; i < ntuples; i++) for (unsigned int i = 0; i < ntuples; i++)
@ -6725,7 +6730,7 @@ sum_kyc_events (void *cls,
&tmp)); &tmp));
} }
} }
@ -6780,16 +6785,16 @@ postgres_get_kyc_status (void *cls,
const char *payto_url, const char *payto_url,
TALER_EXCHANGEDB_KycStatusCallback ksc, TALER_EXCHANGEDB_KycStatusCallback ksc,
void *ksc_cls) void *ksc_cls)
{ {
uint8_t status; uint8_t status;
uint64_t merchant_serial_id; uint64_t merchant_serial_id;
enum GNUNET_DB_QueryStatus qs; enum GNUNET_DB_QueryStatus qs;
char *general_id; char *general_id;
struct GNUNET_PQ_QueryParam params[] = { struct GNUNET_PQ_QueryParam params[] = {
GNUNET_PQ_query_param_string (payto_url), GNUNET_PQ_query_param_string (payto_url),
GNUNET_PQ_query_param_end GNUNET_PQ_query_param_end
}; };
struct GNUNET_PQ_ResultSpec rs[] = { struct GNUNET_PQ_ResultSpec rs[] = {