X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer.c;h=3fcb528d1c0ca87899d6d6142d57829c84cacee4;hp=d7b319452a87088eab5d6cd648fd7515e5b387f5;hb=481d6c57872d621707cf7055432e84a1f54e137b;hpb=03550b580b6963b009582a01dc9cd86f29494e9d

diff --git a/src/common/consumer.c b/src/common/consumer.c
index d7b319452..3fcb528d1 100644
--- a/src/common/consumer.c
+++ b/src/common/consumer.c
@@ -500,6 +500,7 @@ int consumer_update_poll_array(
 	struct lttng_consumer_stream *stream;
 
 	DBG("Updating poll fd array");
+	rcu_read_lock();
 	cds_lfht_for_each_entry(consumer_data.stream_ht->ht, &iter.iter, stream,
 			node.node) {
 		if (stream->state != LTTNG_CONSUMER_ACTIVE_STREAM) {
@@ -511,6 +512,7 @@ int consumer_update_poll_array(
 		local_stream[i] = stream;
 		i++;
 	}
+	rcu_read_unlock();
 
 	/*
 	 * Insert the consumer_poll_pipe at the end of the array and don't