diff options
| author | Christian Grothoff <christian@grothoff.org> | 2019-04-18 14:38:24 +0200 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2019-04-18 14:38:32 +0200 |
| commit | 32a3a0ffb04487fbd1025cdddbf1ff47d0b2b7b5 (patch) | |
| tree | f9df0caf327ecf86a241d4f0435a6dfff1d36dee /src/exchange/taler-exchange-httpd_db.c | |
| parent | 5d3ae9655eb4275a28c9484bde9ca9aa4a14b139 (diff) | |
| download | exchange-32a3a0ffb04487fbd1025cdddbf1ff47d0b2b7b5.tar.gz exchange-32a3a0ffb04487fbd1025cdddbf1ff47d0b2b7b5.tar.bz2 exchange-32a3a0ffb04487fbd1025cdddbf1ff47d0b2b7b5.zip | |
add post HTTP request check for hanging transactions
Diffstat (limited to 'src/exchange/taler-exchange-httpd_db.c')
| -rw-r--r-- | src/exchange/taler-exchange-httpd_db.c | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/src/exchange/taler-exchange-httpd_db.c b/src/exchange/taler-exchange-httpd_db.c index 579f0620b..1f47f8e1a 100644 --- a/src/exchange/taler-exchange-httpd_db.c +++ b/src/exchange/taler-exchange-httpd_db.c @@ -87,9 +87,9 @@ TEH_DB_know_coin_transaction (void *cls, int TEH_DB_run_transaction (struct MHD_Connection *connection, const char *name, - int *mhd_ret, - TEH_DB_TransactionCallback cb, - void *cb_cls) + int *mhd_ret, + TEH_DB_TransactionCallback cb, + void *cb_cls) { struct TALER_EXCHANGEDB_Session *session; @@ -100,7 +100,7 @@ TEH_DB_run_transaction (struct MHD_Connection *connection, GNUNET_break (0); if (NULL != mhd_ret) *mhd_ret = TEH_RESPONSE_reply_internal_db_error (connection, - TALER_EC_DB_SETUP_FAILED); + TALER_EC_DB_SETUP_FAILED); return GNUNET_SYSERR; } TEH_plugin->preflight (TEH_plugin->cls, @@ -110,23 +110,23 @@ TEH_DB_run_transaction (struct MHD_Connection *connection, enum GNUNET_DB_QueryStatus qs; if (GNUNET_OK != - TEH_plugin->start (TEH_plugin->cls, - session, + TEH_plugin->start (TEH_plugin->cls, + session, name)) { GNUNET_break (0); if (NULL != mhd_ret) - *mhd_ret = TEH_RESPONSE_reply_internal_db_error (connection, - TALER_EC_DB_START_FAILED); + *mhd_ret = TEH_RESPONSE_reply_internal_db_error (connection, + TALER_EC_DB_START_FAILED); return GNUNET_SYSERR; } qs = cb (cb_cls, - connection, - session, - mhd_ret); + connection, + session, + mhd_ret); if (0 > qs) TEH_plugin->rollback (TEH_plugin->cls, - session); + session); if (GNUNET_DB_STATUS_HARD_ERROR == qs) return GNUNET_SYSERR; if (0 <= qs) @@ -135,13 +135,13 @@ TEH_DB_run_transaction (struct MHD_Connection *connection, if (GNUNET_DB_STATUS_HARD_ERROR == qs) { if (NULL != mhd_ret) - *mhd_ret = TEH_RESPONSE_reply_commit_error (connection, - TALER_EC_DB_COMMIT_FAILED_HARD); + *mhd_ret = TEH_RESPONSE_reply_commit_error (connection, + TALER_EC_DB_COMMIT_FAILED_HARD); return GNUNET_SYSERR; } /* make sure callback did not violate invariants! */ GNUNET_assert ( (NULL == mhd_ret) || - (-1 == *mhd_ret) ); + (-1 == *mhd_ret) ); if (0 <= qs) return GNUNET_OK; } |