X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=liblttngctl%2Fliblttngctl.c;h=e400775eaa97a6ffcd983cf4f6cd14da695ec18b;hp=76bdf5ffde2ff29b43940f3226f51fc8d5a10329;hb=847177cda88eed885da0b5f0b66b03ffcd06c8f6;hpb=5b97ec606d485e091cf2c2bc06b79f05d18212aa diff --git a/liblttngctl/liblttngctl.c b/liblttngctl/liblttngctl.c index 76bdf5ffd..e400775ea 100644 --- a/liblttngctl/liblttngctl.c +++ b/liblttngctl/liblttngctl.c @@ -39,7 +39,7 @@ static struct lttcomm_lttng_msg llm; /* Prototypes */ static int check_tracing_group(const char *grp_name); -static int ask_sessiond(enum lttcomm_command_type lct, void **buf); +static int ask_sessiond(enum lttcomm_sessiond_command lct, void **buf); static int recv_data_sessiond(void *buf, size_t len); static int send_data_sessiond(void); static int set_session_daemon_path(void); @@ -105,12 +105,17 @@ end: * * Return size of data (only payload, not header). */ -static int ask_sessiond(enum lttcomm_command_type lct, void **buf) +static int ask_sessiond(enum lttcomm_sessiond_command lct, void **buf) { int ret; size_t size; void *data = NULL; + ret = lttng_connect_sessiond(); + if (ret < 0) { + goto end; + } + lsm.cmd_type = lct; /* Send command to session daemon */ @@ -131,7 +136,7 @@ static int ask_sessiond(enum lttcomm_command_type lct, void **buf) goto end; } - size = llm.size_payload; + size = llm.trace_name_offset + llm.data_size; if (size == 0) { goto end; } @@ -148,7 +153,7 @@ static int ask_sessiond(enum lttcomm_command_type lct, void **buf) ret = size; end: - /* Reset lsm data struct */ + lttng_disconnect_sessiond(); memset(&lsm, 0, sizeof(lsm)); return ret; } @@ -245,7 +250,7 @@ int lttng_list_traces(uuid_t *uuid, struct lttng_trace **traces) { int ret; - uuid_copy(lsm.session_id, *uuid); + uuid_copy(lsm.session_uuid, *uuid); ret = ask_sessiond(LTTNG_LIST_TRACES, (void **) traces); if (ret < 0) { @@ -273,7 +278,7 @@ int lttng_create_session(char *name, uuid_t *session_id) goto end; } - uuid_copy(*session_id, llm.session_id); + uuid_copy(*session_id, llm.session_uuid); end: return ret; @@ -288,7 +293,7 @@ int lttng_destroy_session(uuid_t *uuid) { int ret; - uuid_copy(lsm.session_id, *uuid); + uuid_copy(lsm.session_uuid, *uuid); ret = ask_sessiond(LTTNG_DESTROY_SESSION, NULL); if (ret < 0) { @@ -370,9 +375,9 @@ int lttng_disconnect_sessiond(void) * * Set the session uuid for current lsm. */ -void lttng_set_current_session_uuid(char *uuid) +void lttng_set_current_session_uuid(uuid_t *uuid) { - uuid_parse(uuid, lsm.session_id); + uuid_copy(lsm.session_uuid, *uuid); } /* @@ -426,7 +431,7 @@ static int set_session_daemon_path(void) /* Are we in the tracing group ? */ ret = check_tracing_group(tracing_group); - if (ret < 0) { + if (ret < 0 && getuid() != 0) { if (sprintf(sessiond_sock_path, DEFAULT_HOME_CLIENT_UNIX_SOCK, getenv("HOME")) < 0) { return -ENOMEM;