rarias/ovni
rarias/ovni
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Print info when reaching the end of sort window

Browse Source
This commit is contained in:
Rodrigo Arias 2022-10-07 11:22:29 +02:00
parent 035791ff54
commit b8e521b49c
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/sort.c
View File

@ -87,13 +87,14 @@ static ssize_t
find_destination(struct ring *r, uint64_t clock) find_destination(struct ring *r, uint64_t clock)
{ {
ssize_t nback = 0; ssize_t nback = 0;
ssize_t i = 0;
UNUSED(nback); UNUSED(nback);
ssize_t start = r->tail - 1 >= 0 ? r->tail - 1 : r->size - 1; ssize_t start = r->tail - 1 >= 0 ? r->tail - 1 : r->size - 1;
ssize_t end = r->head - 1 >= 0 ? r->head - 1 : r->size - 1; ssize_t end = r->head - 1 >= 0 ? r->head - 1 : r->size - 1;
for (ssize_t i = start; i != end; i = i - 1 < 0 ? r->size - 1 : i - 1) { for (i = start; i != end; i = i - 1 < 0 ? r->size - 1 : i - 1) {
if (r->ev[i]->header.clock < clock) { if (r->ev[i]->header.clock < clock) {
dbg("found suitable position %ld events backwards\n", dbg("found suitable position %ld events backwards\n",
nback); nback);
@ -103,6 +104,7 @@ find_destination(struct ring *r, uint64_t clock)
} }
err("cannot find a event previous to clock %lu\n", clock); err("cannot find a event previous to clock %lu\n", clock);
err("nback = %ld, last clock=%lu\n", nback, r->ev[i]->header.clock);
return -1; return -1;
} }