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

Fix ovnisort check too

Browse Source
This commit is contained in:
Rodrigo Arias 2022-10-07 11:02:03 +02:00
parent 362c47553b
commit 37a636f387
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/sort.c
View File

@ -295,13 +295,14 @@ stream_winsort(struct ovni_stream *stream, struct ring *r)
static int static int
stream_check(struct ovni_stream *stream) stream_check(struct ovni_stream *stream)
{ {
ovni_load_next_event(stream); if (ovni_load_next_event(stream) != 0)
return 0;
struct ovni_ev *ev = stream->cur_ev; struct ovni_ev *ev = stream->cur_ev;
uint64_t last_clock = ev->header.clock; uint64_t last_clock = ev->header.clock;
int ret = 0; int ret = 0;
while (stream->active) { while (ovni_load_next_event(stream) == 0) {
ovni_load_next_event(stream);
ev = stream->cur_ev; ev = stream->cur_ev;
uint64_t cur_clock = ovni_ev_get_clock(ev); uint64_t cur_clock = ovni_ev_get_clock(ev);