X-Git-Url: http://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fust-app.c;fp=src%2Fbin%2Flttng-sessiond%2Fust-app.c;h=5c66776d4901c42ed44b19a591f56c32f188147e;hp=5380450f643a31cce3fa3e2eb1bb8ca994fb20ff;hb=840a73344734b584f7033a2b76628b28c2fa57bf;hpb=6684bfa4a76f566ff024d4f2159f59f2e783d8c2

diff --git a/src/bin/lttng-sessiond/ust-app.c b/src/bin/lttng-sessiond/ust-app.c
index 5380450f6..5c66776d4 100644
--- a/src/bin/lttng-sessiond/ust-app.c
+++ b/src/bin/lttng-sessiond/ust-app.c
@@ -2055,6 +2055,31 @@ int ust_app_start_trace(struct ltt_ust_session *usess, struct ust_app *app)
 		goto error_rcu_unlock;
 	}
 
+	/* Ask UST to open the write side of the wait pipe */
+	DBG("Asking UST to open metadata stream wait pipe path: %s\n",
+	    ua_sess->metadata->stream_obj->wait_pipe_path);
+
+	ret = ustctl_open_wait_pipe(app->sock, ua_sess->metadata->obj);
+
+	if (ret < 0) {
+		ERR("Asking UST to open wait_pipe failed");
+	}
+
+	/* each channel */
+	cds_lfht_for_each_entry(ua_sess->channels->ht, &iter.iter, ua_chan,
+				node.node) {
+
+		DBG("Asking UST to open channel wait pipe path: %s\n",
+		    ua_chan->obj->wait_pipe_path);
+
+		ret = ustctl_open_wait_pipe(app->sock, ua_chan->obj);
+
+		if (ret < 0) {
+			ERR("Asking UST to open wait_pipe failed for wait pipe: %s",
+			    ua_chan->obj->wait_pipe_path);
+		}
+	}
+
 skip_setup:
 	/* This start the UST tracing */
 	ret = ustctl_start_session(app->sock, ua_sess->handle);