X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fmain.c;h=ebbe5e3930af3ea8b559054fdab8cbdc3d3eab6a;hb=4e9a468645939ea62541fa802893b928b01888b7;hp=0f81d556dd4df73a910471756b75cf6567581a36;hpb=c8f59ee5fc11492ef472dc5cfd2fd2c4926b1787;p=lttng-tools.git 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 {