X-Git-Url: http://git.lttng.org/?a=blobdiff_plain;ds=inline;f=ustd%2Fustd.c;h=d5884dfe040c8bed7667a03e06784e444023c0e1;hb=3bb568630e172fd8d2a05f85b6f44218c18ce139;hp=830d5e26441fe368b975b2c8b75fe44dd5e93060;hpb=1f8b0dffac11b11fa7b582b6274c6b4cadf57bb3;p=ust.git

diff --git a/ustd/ustd.c b/ustd/ustd.c
index 830d5e2..d5884df 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;
@@ -64,9 +65,9 @@ int get_subbuffer(struct buffer_info *buf)
 	int result;
 
 	asprintf(&send_msg, "get_subbuffer %s", buf->name);
-	result = send_message(buf->pid, send_msg, &received_msg);
+	result = ustcomm_send_request(&buf->conn, send_msg, &received_msg);
 	if(result < 0) {
-		ERR("get_subbuffer: send_message failed");
+		ERR("get_subbuffer: ustcomm_send_request failed");
 		return -1;
 	}
 	free(send_msg);
@@ -106,7 +107,7 @@ int put_subbuffer(struct buffer_info *buf)
 	int result;
 
 	asprintf(&send_msg, "put_subbuffer %s %ld", buf->name, buf->consumed_old);
-	result = send_message(buf->pid, send_msg, &received_msg);
+	result = ustcomm_send_request(&buf->conn, send_msg, &received_msg);
 	if(result < 0) {
 		ERR("put_subbuffer: send_message failed");
 		return -1;
@@ -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);