X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fust-app.c;h=56860d714e3a6e5a605e75c56a1fb200037fd1bb;hp=8c9277cae225ea80e9df7bf106d304a529e71769;hb=3b9677124ab48bddc945ca67947c49b87b5853e0;hpb=ecd1a12fac39784bded85c0f06e47ace2dc98cde

diff --git a/src/bin/lttng-sessiond/ust-app.c b/src/bin/lttng-sessiond/ust-app.c
index 8c9277cae..56860d714 100644
--- a/src/bin/lttng-sessiond/ust-app.c
+++ b/src/bin/lttng-sessiond/ust-app.c
@@ -5883,7 +5883,6 @@ enum lttng_error_code ust_app_snapshot_record(
 	enum lttng_error_code status = LTTNG_OK;
 	struct lttng_ht_iter iter;
 	struct ust_app *app;
-	char pathname[PATH_MAX];
 
 	assert(usess);
 	assert(output);
@@ -5898,6 +5897,8 @@ enum lttng_error_code ust_app_snapshot_record(
 		cds_list_for_each_entry(reg, &usess->buffer_reg_uid_list, lnode) {
 			struct buffer_reg_channel *reg_chan;
 			struct consumer_socket *socket;
+			char *trace_path = NULL;
+			char pathname[PATH_MAX];
 
 			if (!reg->registry->reg.ust->metadata_key) {
 				/* Skip since no metadata is present */
@@ -5925,22 +5926,28 @@ enum lttng_error_code ust_app_snapshot_record(
 				status = LTTNG_ERR_INVALID;
 				goto error;
 			}
-
+			trace_path = setup_channel_trace_path(usess->consumer, pathname);
+			if (!trace_path) {
+				status = LTTNG_ERR_INVALID;
+				goto error;
+			}
                         /* Add the UST default trace dir to path. */
 			cds_lfht_for_each_entry(reg->registry->channels->ht, &iter.iter,
 					reg_chan, node.node) {
 				status = consumer_snapshot_channel(socket,
 						reg_chan->consumer_key,
 						output, 0, usess->uid,
-						usess->gid, pathname, wait,
+						usess->gid, trace_path, wait,
 						nb_packets_per_stream);
 				if (status != LTTNG_OK) {
+					free(trace_path);
 					goto error;
 				}
 			}
 			status = consumer_snapshot_channel(socket,
 					reg->registry->reg.ust->metadata_key, output, 1,
-					usess->uid, usess->gid, pathname, wait, 0);
+					usess->uid, usess->gid, trace_path, wait, 0);
+			free(trace_path);
 			if (status != LTTNG_OK) {
 				goto error;
 			}
@@ -5955,6 +5962,8 @@ enum lttng_error_code ust_app_snapshot_record(
 			struct ust_app_channel *ua_chan;
 			struct ust_app_session *ua_sess;
 			struct ust_registry_session *registry;
+			char *trace_path = NULL;
+			char pathname[PATH_MAX];
 
 			ua_sess = lookup_session_by_app(usess, app);
 			if (!ua_sess) {
@@ -5979,7 +5988,11 @@ enum lttng_error_code ust_app_snapshot_record(
 				PERROR("snprintf snapshot path");
 				goto error;
 			}
-
+			trace_path = setup_channel_trace_path(usess->consumer, pathname);
+			if (!trace_path) {
+				status = LTTNG_ERR_INVALID;
+				goto error;
+			}
                         cds_lfht_for_each_entry(ua_sess->channels->ht, &chan_iter.iter,
 					ua_chan, node.node) {
 				status = consumer_snapshot_channel(socket,
@@ -5988,14 +6001,16 @@ enum lttng_error_code ust_app_snapshot_record(
 								.uid,
 						ua_sess->effective_credentials
 								.gid,
-						pathname, wait,
+						trace_path, wait,
 						nb_packets_per_stream);
 				switch (status) {
 				case LTTNG_OK:
 					break;
 				case LTTNG_ERR_CHAN_NOT_FOUND:
+					free(trace_path);
 					continue;
 				default:
+					free(trace_path);
 					goto error;
 				}
 			}
@@ -6009,7 +6024,8 @@ enum lttng_error_code ust_app_snapshot_record(
 					registry->metadata_key, output, 1,
 					ua_sess->effective_credentials.uid,
 					ua_sess->effective_credentials.gid,
-					pathname, wait, 0);
+					trace_path, wait, 0);
+			free(trace_path);
 			switch (status) {
 			case LTTNG_OK:
 				break;