summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2022-05-21 01:41:02 +0200
committerChristian Grothoff <christian@grothoff.org>2022-05-21 01:41:02 +0200
commit9e0df07a16f5be870ef8dce24892168e4f966a63 (patch)
tree38b4ddebb99b313b725f8c7d0541f30ec648875b
parentc471ae447b285c33ef51cd50b8e0cc36d9c0a794 (diff)
downloadexchange-9e0df07a16f5be870ef8dce24892168e4f966a63.tar.gz
exchange-9e0df07a16f5be870ef8dce24892168e4f966a63.tar.bz2
exchange-9e0df07a16f5be870ef8dce24892168e4f966a63.zip
latest_row_off is exclusive, remove bad comment
-rw-r--r--src/exchange/taler-exchange-wirewatch.c3
1 files changed, 1 insertions, 2 deletions
diff --git a/src/exchange/taler-exchange-wirewatch.c b/src/exchange/taler-exchange-wirewatch.c
index 8e453830..24f92efa 100644
--- a/src/exchange/taler-exchange-wirewatch.c
+++ b/src/exchange/taler-exchange-wirewatch.c
@@ -578,7 +578,6 @@ history_cb (void *cls,
}
if (serial_id < wa->latest_row_off)
{
- /* we are done with the current shard, commit and stop this iteration! */
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"Serial ID %llu not monotonic (got %llu before). Failing!\n",
(unsigned long long) serial_id,
@@ -601,7 +600,7 @@ history_cb (void *cls,
"Serial ID %llu past shard end at %llu, ending iteration early!\n",
(unsigned long long) serial_id,
(unsigned long long) wa->shard_end);
- wa->latest_row_off = serial_id - 1;
+ wa->latest_row_off = serial_id;
if (wa->started_transaction)
{
do_commit (wa);