exchange

commit 4cd70bc0a7d565547d673fcef2cade2ee2df4a4b
parent 1a1fafbd438f3f21a15c990d904e192b045d2391
Author: Christian Grothoff <christian@grothoff.org>
Date:   Tue, 14 Dec 2021 16:26:10 +0100

fix shard delay calculation also for 'transfer' tool

Diffstat:
M
src/exchange/taler-exchange-transfer.c
 | 
13
+++++++++++--

1 file changed, 11 insertions(+), 2 deletions(-)
diff --git a/src/exchange/taler-exchange-transfer.c b/src/exchange/taler-exchange-transfer.c
@@ -201,7 +201,7 @@ static unsigned int shard_size = DEFAULT_BATCH_SIZE;
 /**
  * How many workers should we plan our scheduling with?
  */
-static unsigned int max_workers = 16;
+static unsigned int max_workers = 0;
 
 
 /**
@@ -338,6 +338,15 @@ static void
 run_transfers (void *cls);
 
 
+static void
+run_transfers_delayed (void *cls)
+{
+  (void) cls;
+  shard->shard_start_time = GNUNET_TIME_absolute_get ();
+  run_transfers (NULL);
+}
+
+
 /**
  * Select shard to process.
  *
@@ -710,7 +719,7 @@ run_transfers (void *cls)
                   "No more pending wire transfers, going idle\n");
       GNUNET_assert (NULL == task);
       task = GNUNET_SCHEDULER_add_delayed (transfer_idle_sleep_interval,
-                                           &run_transfers,
+                                           &run_transfers_delayed,
                                            NULL);
     }
     return;