diff options
| -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 8f69ba7b..a417342a 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; |