X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=ustd%2Fustd.c;h=b66f1ced7e9e83788ee88ce00a72012464f83388;hb=4e2a88089f60f56b118bbfcbac65f74e79166436;hp=830d5e26441fe368b975b2c8b75fe44dd5e93060;hpb=1f8b0dffac11b11fa7b582b6274c6b4cadf57bb3;p=ust.git

diff --git a/ustd/ustd.c b/ustd/ustd.c
index 830d5e2..b66f1ce 100644
--- a/ustd/ustd.c
+++ b/ustd/ustd.c
@@ -35,6 +35,7 @@ struct list_head buffers = LIST_HEAD_INIT(buffers);
 struct buffer_info {
 	char *name;
 	pid_t pid;
+	struct ustcomm_connection conn;
 
 	int shmid;
 	void *mem;
@@ -207,9 +208,16 @@ int add_buffer(pid_t pid, char *bufname)
 	buf->name = bufname;
 	buf->pid = pid;
 
+	/* connect to app */
+	result = ustcomm_connect_app(buf->pid, &buf->conn);
+	if(result) {
+		ERR("unable to connect to process");
+		return -1;
+	}
+
 	/* get shmid */
 	asprintf(&send_msg, "get_shmid %s", buf->name);
-	send_message(pid, send_msg, &received_msg);
+	ustcomm_send_request(&buf->conn, send_msg, &received_msg);
 	free(send_msg);
 	DBG("got buffer name %s", buf->name);
 
@@ -223,7 +231,7 @@ int add_buffer(pid_t pid, char *bufname)
 
 	/* get n_subbufs */
 	asprintf(&send_msg, "get_n_subbufs %s", buf->name);
-	send_message(pid, send_msg, &received_msg);
+	ustcomm_send_request(&buf->conn, send_msg, &received_msg);
 	free(send_msg);
 
 	result = sscanf(received_msg, "%d", &buf->n_subbufs);
@@ -236,7 +244,7 @@ int add_buffer(pid_t pid, char *bufname)
 
 	/* get subbuf size */
 	asprintf(&send_msg, "get_subbuf_size %s", buf->name);
-	send_message(pid, send_msg, &received_msg);
+	ustcomm_send_request(&buf->conn, send_msg, &received_msg);
 	free(send_msg);
 
 	result = sscanf(received_msg, "%d", &buf->subbuf_size);