latest_row_off is exclusive, remove bad comment
This commit is contained in:
parent
c471ae447b
commit
9e0df07a16
@ -578,7 +578,6 @@ history_cb (void *cls,
|
|||||||
}
|
}
|
||||||
if (serial_id < wa->latest_row_off)
|
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,
|
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
|
||||||
"Serial ID %llu not monotonic (got %llu before). Failing!\n",
|
"Serial ID %llu not monotonic (got %llu before). Failing!\n",
|
||||||
(unsigned long long) serial_id,
|
(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",
|
"Serial ID %llu past shard end at %llu, ending iteration early!\n",
|
||||||
(unsigned long long) serial_id,
|
(unsigned long long) serial_id,
|
||||||
(unsigned long long) wa->shard_end);
|
(unsigned long long) wa->shard_end);
|
||||||
wa->latest_row_off = serial_id - 1;
|
wa->latest_row_off = serial_id;
|
||||||
if (wa->started_transaction)
|
if (wa->started_transaction)
|
||||||
{
|
{
|
||||||
do_commit (wa);
|
do_commit (wa);
|
||||||
|
Loading…
Reference in New Issue
Block a user