From ac4247f53a7abcc954feeec1899487d6bd83c01d Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Thu, 9 Dec 2021 14:40:06 +0100 Subject: -note on #7124 --- src/exchange/taler-exchange-wirewatch.c | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) 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; -- cgit v1.2.3