X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fmain.c;h=730eaf203102886b206aa5d267afc2f8bc9e98b6;hp=380b4f833042cad3dcf7809e1871016fda753506;hb=80e8027abb847655ebe43b2b5aec1a5141bb9668;hpb=4a9daf1745ccbd2aab029206a664f39fcbd640ce

diff --git a/src/bin/lttng-relayd/main.c b/src/bin/lttng-relayd/main.c
index 380b4f833..730eaf203 100644
--- a/src/bin/lttng-relayd/main.c
+++ b/src/bin/lttng-relayd/main.c
@@ -1160,6 +1160,7 @@ int relay_create_session(struct lttcomm_relayd_hdr *recv_hdr,
 	session->sock = cmd->sock;
 	session->minor = cmd->minor;
 	session->major = cmd->major;
+	pthread_mutex_init(&session->viewer_ready_lock, NULL);
 	cmd->session = session;
 
 	reply.session_id = htobe64(session->id);
@@ -1207,6 +1208,8 @@ void set_viewer_ready_flag(struct relay_command *cmd)
 {
 	struct relay_stream_recv_handle *node, *tmp_node;
 
+	pthread_mutex_lock(&cmd->session->viewer_ready_lock);
+
 	cds_list_for_each_entry_safe(node, tmp_node, &cmd->recv_head, node) {
 		struct relay_stream *stream;
 
@@ -1229,6 +1232,7 @@ void set_viewer_ready_flag(struct relay_command *cmd)
 		free(node);
 	}
 
+	pthread_mutex_unlock(&cmd->session->viewer_ready_lock);
 	return;
 }