X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fmain.c;h=ebbe5e3930af3ea8b559054fdab8cbdc3d3eab6a;hp=0f81d556dd4df73a910471756b75cf6567581a36;hb=33832e643df265121266c16fd5dc54313e86e20f;hpb=df27ef7b025240e4b93a74193fb61569fb8d3d14 diff --git a/src/bin/lttng-relayd/main.c b/src/bin/lttng-relayd/main.c index 0f81d556d..ebbe5e393 100644 --- a/src/bin/lttng-relayd/main.c +++ b/src/bin/lttng-relayd/main.c @@ -1355,7 +1355,8 @@ int relay_data_available(struct lttcomm_relayd_hdr *recv_hdr, " and last_seq %" PRIu64, stream_id, stream->prev_seq, last_net_seq_num); - if (stream->prev_seq == -1UL || stream->prev_seq <= last_net_seq_num) { + /* Avoid wrapping issue */ + if (((int64_t) (stream->prev_seq - last_net_seq_num)) <= 0) { /* Data has in fact been written and is available */ ret = 1; } else {