From 2280aad182048e5726940eab9b42a00f5f92b53a Mon Sep 17 00:00:00 2001 From: Mathieu Desnoyers Date: Mon, 19 Nov 2018 16:09:28 -0500 Subject: [PATCH] Fix: relayd: rotation pending off-by-one MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit We need to compare with <= rather than < in the rotation pending check on the relay daemon side, similarly to the check done in the consumer daemon check_stream_rotation_pending(). Signed-off-by: Mathieu Desnoyers Signed-off-by: Jérémie Galarneau --- src/bin/lttng-relayd/main.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/bin/lttng-relayd/main.c b/src/bin/lttng-relayd/main.c index 09aeb33e0..de14cdb43 100644 --- a/src/bin/lttng-relayd/main.c +++ b/src/bin/lttng-relayd/main.c @@ -2973,7 +2973,7 @@ int relay_rotate_pending(const struct lttcomm_relayd_hdr *recv_hdr, rotate_pending = true; DBG("Stream %" PRIu64 " is still rotating", stream->stream_handle); - } else if (stream->current_chunk_id.value < chunk_id) { + } else if (stream->current_chunk_id.value <= chunk_id) { /* * Stream closed on the consumer but still active on the * relay. -- 2.34.1