diff options
| author | Christian Grothoff <christian@grothoff.org> | 2021-12-14 16:26:10 +0100 | 
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2021-12-14 16:26:10 +0100 | 
| commit | 4cd70bc0a7d565547d673fcef2cade2ee2df4a4b (patch) | |
| tree | b60d87163e6e72424ddcb2f06c0c7e97dd0a15ae | |
| parent | 1a1fafbd438f3f21a15c990d904e192b045d2391 (diff) | |
fix shard delay calculation also for 'transfer' tool
| -rw-r--r-- | src/exchange/taler-exchange-transfer.c | 13 | 
1 files changed, 11 insertions, 2 deletions
| diff --git a/src/exchange/taler-exchange-transfer.c b/src/exchange/taler-exchange-transfer.c index 261b4006..011da6b5 100644 --- 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; | 
