summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2022-05-24 10:11:43 +0200
committerChristian Grothoff <christian@grothoff.org>2022-05-24 10:11:43 +0200
commit92e04e0a3f31a9407b3f8e6e8f615000a57c726f (patch)
tree1a41c05a72cfe6fb8fe53dc6fc2d453f56e70dba
parentdaddc69dc9bfdcc521bb7cada925e77441d36f7d (diff)
downloadexchange-92e04e0a3f31a9407b3f8e6e8f615000a57c726f.tar.gz
exchange-92e04e0a3f31a9407b3f8e6e8f615000a57c726f.tar.bz2
exchange-92e04e0a3f31a9407b3f8e6e8f615000a57c726f.zip
-handle serialization issue
-rw-r--r--src/exchange/taler-exchange-wirewatch.c7
1 files changed, 5 insertions, 2 deletions
diff --git a/src/exchange/taler-exchange-wirewatch.c b/src/exchange/taler-exchange-wirewatch.c
index a5efda72c..85e73d1be 100644
--- a/src/exchange/taler-exchange-wirewatch.c
+++ b/src/exchange/taler-exchange-wirewatch.c
@@ -546,8 +546,6 @@ do_commit (struct WireAccount *wa)
GNUNET_assert (NULL == task);
shard_done = check_shard_done (wa);
wa->started_transaction = false;
- if (shard_done)
- wa->shard_open = false;
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Committing %s progress (%llu,%llu] at %llu\n (%s)",
wa->job_name,
@@ -574,10 +572,15 @@ do_commit (struct WireAccount *wa)
break;
}
if (shard_done)
+ {
+ wa->shard_open = false;
account_completed (wa);
+ }
else
+ {
task = GNUNET_SCHEDULER_add_now (&continue_with_shard,
wa);
+ }
}