diff options
| author | Christian Grothoff <christian@grothoff.org> | 2021-12-09 14:40:06 +0100 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2021-12-09 14:40:06 +0100 |
| commit | ac4247f53a7abcc954feeec1899487d6bd83c01d (patch) | |
| tree | 71e6ff6c4dfbfaa0f60dc7c210e3ee6ed0ffbe4c | |
| parent | a7b4cc97ecfe2452064c8ac2f05b8d7890c8576b (diff) | |
| download | exchange-ac4247f53a7abcc954feeec1899487d6bd83c01d.tar.gz exchange-ac4247f53a7abcc954feeec1899487d6bd83c01d.tar.bz2 exchange-ac4247f53a7abcc954feeec1899487d6bd83c01d.zip | |
-note on #7124
| -rw-r--r-- | src/exchange/taler-exchange-wirewatch.c | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/exchange/taler-exchange-wirewatch.c b/src/exchange/taler-exchange-wirewatch.c index 8f69ba7b1..a417342a2 100644 --- a/src/exchange/taler-exchange-wirewatch.c +++ b/src/exchange/taler-exchange-wirewatch.c @@ -234,6 +234,12 @@ shutdown_task (void *cls) GNUNET_CONTAINER_DLL_remove (wa_head, wa_tail, wa); + if (wa->started_transaction) + { + db_plugin->rollback (db_plugin->cls); + wa->started_transaction = false; + } + // FIXME: delete shard lock here (#7124) GNUNET_free (wa->job_name); GNUNET_free (wa); } @@ -557,6 +563,7 @@ history_cb (void *cls, wa->hh = NULL; return GNUNET_SYSERR; } + wa_pos->shard_start_time = GNUNET_TIME_absolute_get (); wa->started_transaction = true; } GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, @@ -669,7 +676,6 @@ find_transfers (void *cls) NULL); return; case GNUNET_DB_STATUS_SUCCESS_ONE_RESULT: - wa_pos->shard_start_time = GNUNET_TIME_absolute_get (); wa_pos->shard_start = start; wa_pos->shard_end = end; wa_pos->batch_start = start; |