From 2c8a890846cfc88874b25d5c3c12e0fd5ce3d1da Mon Sep 17 00:00:00 2001 From: =?utf8?q?J=C3=A9r=C3=A9mie=20Galarneau?= Date: Thu, 8 Nov 2018 12:09:04 -0500 Subject: [PATCH] Remove unused nr_stream_rotate_pending from consumer channel MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit Signed-off-by: Jérémie Galarneau --- src/common/consumer/consumer.c | 1 - src/common/consumer/consumer.h | 7 ------- 2 files changed, 8 deletions(-) diff --git a/src/common/consumer/consumer.c b/src/common/consumer/consumer.c index 6de72e275..b07939113 100644 --- a/src/common/consumer/consumer.c +++ b/src/common/consumer/consumer.c @@ -3984,7 +3984,6 @@ int lttng_consumer_rotate_channel(uint64_t key, const char *path, if (consumed_pos == stream->rotate_position) { stream->rotate_ready = true; } - channel->nr_stream_rotate_pending++; ret = consumer_flush_buffer(stream, 1); if (ret < 0) { diff --git a/src/common/consumer/consumer.h b/src/common/consumer/consumer.h index d4e9f066a..2c927bbc2 100644 --- a/src/common/consumer/consumer.h +++ b/src/common/consumer/consumer.h @@ -233,13 +233,6 @@ struct lttng_consumer_channel { bool streams_sent_to_relayd; - /* - * Account how many streams are waiting for their rotation to be - * complete. When this number reaches 0, we inform the session - * daemon that this channel has finished its rotation. - */ - uint64_t nr_stream_rotate_pending; - /* * The chunk id where we currently write the data. This value is sent * to the relay when we add a stream and when a stream rotates. This -- 2.34.1