X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fmain.c;h=a63593d18030c0c1f88c34f4f331c6de2fdf2f47;hp=e5a22460fc3c6fe2342bf82d015d6da84a85ffd2;hb=fdd9eb17f6b6928771744bb40bb2283ce3340033;hpb=35f90c40cf023393851ac47ad526a0e9e1184503

diff --git a/src/bin/lttng-sessiond/main.c b/src/bin/lttng-sessiond/main.c
index e5a22460f..a63593d18 100644
--- a/src/bin/lttng-sessiond/main.c
+++ b/src/bin/lttng-sessiond/main.c
@@ -638,7 +638,7 @@ static int update_kernel_stream(struct consumer_data *consumer_data, int fd)
 					struct lttng_ht_iter iter;
 					struct consumer_socket *socket;
 
-
+					rcu_read_lock();
 					cds_lfht_for_each_entry(ksess->consumer->socks->ht,
 							&iter.iter, socket, node.node) {
 						/* Code flow error */
@@ -649,9 +649,11 @@ static int update_kernel_stream(struct consumer_data *consumer_data, int fd)
 								channel, ksess);
 						pthread_mutex_unlock(socket->lock);
 						if (ret < 0) {
+							rcu_read_unlock();
 							goto error;
 						}
 					}
+					rcu_read_unlock();
 				}
 				goto error;
 			}
@@ -2102,7 +2104,7 @@ static int create_ust_session(struct ltt_session *session,
 
 	DBG("Creating UST session");
 
-	lus = trace_ust_create_session(session->path, session->id, domain);
+	lus = trace_ust_create_session(session->path, session->id);
 	if (lus == NULL) {
 		ret = LTTNG_ERR_UST_SESS_FAIL;
 		goto error;