exchange

commit ac4247f53a7abcc954feeec1899487d6bd83c01d
parent a7b4cc97ecfe2452064c8ac2f05b8d7890c8576b
Author: Christian Grothoff <christian@grothoff.org>
Date:   Thu,  9 Dec 2021 14:40:06 +0100

-note on #7124

Diffstat:
M
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
@@ -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;