diff options
| author | Christian Grothoff <christian@grothoff.org> | 2021-12-11 14:03:08 +0100 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2021-12-11 14:03:08 +0100 |
| commit | 4eb958846fdd91f3f912665bd0c0295e8eebcf1d (patch) | |
| tree | 6c6937ad8598bf4c4d6ce6c42aeca862493fe1a4 /src | |
| parent | 386301d1cf48ad3c87df1733cd7a82957ff6c383 (diff) | |
| download | exchange-4eb958846fdd91f3f912665bd0c0295e8eebcf1d.tar.xz | |
-more logging, less hanging ;-)
Diffstat (limited to 'src')
| -rw-r--r-- | src/exchange/taler-exchange-wirewatch.c | 31 |
1 files changed, 29 insertions, 2 deletions
diff --git a/src/exchange/taler-exchange-wirewatch.c b/src/exchange/taler-exchange-wirewatch.c index eb0449942..6b63de76a 100644 --- a/src/exchange/taler-exchange-wirewatch.c +++ b/src/exchange/taler-exchange-wirewatch.c @@ -410,6 +410,11 @@ shard_completed (struct WireAccount *wa) GNUNET_assert (NULL != wa_pos); } GNUNET_assert (NULL == task); + GNUNET_log (GNUNET_ERROR_TYPE_INFO, + "Will look for more transfers in %s\n", + GNUNET_STRINGS_relative_time_to_string ( + GNUNET_TIME_absolute_get_remaining (wa_pos->delayed_until), + GNUNET_YES)); task = GNUNET_SCHEDULER_add_at (wa_pos->delayed_until, &find_transfers, NULL); @@ -527,6 +532,11 @@ history_cb (void *cls, (unsigned int) ec, http_status); } + else + { + GNUNET_log (GNUNET_ERROR_TYPE_INFO, + "History response complete\n"); + } if (wa->started_transaction) { GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, @@ -544,6 +554,10 @@ history_cb (void *cls, GNUNET_SCHEDULER_shutdown (); return GNUNET_OK; } + else + { + shard_completed (wa); + } } return GNUNET_OK; /* will be ignored anyway */ } @@ -700,12 +714,22 @@ find_transfers (void *cls) return; case GNUNET_DB_STATUS_SOFT_ERROR: /* try again */ + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "Serialization error tying to obtain shard, will try again in %s!\n", + GNUNET_STRINGS_relative_time_to_string ( + wirewatch_idle_sleep_interval, + GNUNET_YES)); task = GNUNET_SCHEDULER_add_delayed (wirewatch_idle_sleep_interval, &find_transfers, NULL); return; case GNUNET_DB_STATUS_SUCCESS_NO_RESULTS: GNUNET_break (0); + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "No shard available, will try again in %s!\n", + GNUNET_STRINGS_relative_time_to_string ( + wirewatch_idle_sleep_interval, + GNUNET_YES)); task = GNUNET_SCHEDULER_add_delayed (wirewatch_idle_sleep_interval, &find_transfers, NULL); @@ -715,8 +739,11 @@ find_transfers (void *cls) wa_pos->shard_end = end; wa_pos->batch_start = start; GNUNET_log (GNUNET_ERROR_TYPE_INFO, - "Starting with shard at %llu\n", - (unsigned long long) start); + "Starting with shard at [%llu,%llu) locked for %s\n", + (unsigned long long) start, + (unsigned long long) end, + GNUNET_STRINGS_relative_time_to_string (delay, + GNUNET_YES)); break; } } |