X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Findex.cpp;h=6cf131b256757cba64ab7796ea50a19cd0c20a8a;hb=1c9a0b0e83c7e073c4e576c0bed95de335b0e502;hp=f2f102e64d4714d945551435dc5f41e83cb394db;hpb=0f1b1d2510d23e9a2a4baa9e2642ef97a35ef83f;p=lttng-tools.git

diff --git a/src/bin/lttng-relayd/index.cpp b/src/bin/lttng-relayd/index.cpp
index f2f102e64..6cf131b25 100644
--- a/src/bin/lttng-relayd/index.cpp
+++ b/src/bin/lttng-relayd/index.cpp
@@ -67,6 +67,8 @@ static struct relay_index *relay_index_add_unique(struct relay_stream *stream,
 	struct cds_lfht_node *node_ptr;
 	struct relay_index *_index;
 
+	ASSERT_RCU_READ_LOCKED();
+
 	DBG2("Adding relay index with stream id %" PRIu64 " and seqnum %" PRIu64,
 			stream->stream_handle, index->index_n.key);
 
@@ -88,6 +90,8 @@ static struct relay_index *relay_index_add_unique(struct relay_stream *stream,
  */
 static bool relay_index_get(struct relay_index *index)
 {
+	ASSERT_RCU_READ_LOCKED();
+
 	DBG2("index get for stream id %" PRIu64 " and seqnum %" PRIu64 " refcount %d",
 			index->stream->stream_handle, index->index_n.key,
 			(int) index->ref.refcount);