X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Flib%2Flttng-ctl%2Flttng-ctl.c;h=bbe7cb4180dda914676714496fe31c56d09bf56e;hp=67c5972191016d8eafbf74d1e34faea0e8221e7f;hb=61b35a5aa71d4c0715f390a32cb4e967e817c81f;hpb=38ee087f699718e57d1bc5614c2f79c3c30ccca9 diff --git a/src/lib/lttng-ctl/lttng-ctl.c b/src/lib/lttng-ctl/lttng-ctl.c index 67c597219..bbe7cb418 100644 --- a/src/lib/lttng-ctl/lttng-ctl.c +++ b/src/lib/lttng-ctl/lttng-ctl.c @@ -708,7 +708,7 @@ static int _lttng_stop_tracing(const char *session_name, int wait) /* Check for data availability */ do { - data_ret = lttng_data_available(session_name); + data_ret = lttng_data_pending(session_name); if (data_ret < 0) { /* Return the data available call error. */ ret = data_ret; @@ -719,11 +719,11 @@ static int _lttng_stop_tracing(const char *session_name, int wait) * Data sleep time before retrying (in usec). Don't sleep if the call * returned value indicates availability. */ - if (!data_ret) { + if (data_ret) { usleep(DEFAULT_DATA_AVAILABILITY_WAIT_TIME); _MSG("."); } - } while (data_ret != 1); + } while (data_ret != 0); MSG(""); @@ -1606,7 +1606,8 @@ int _lttng_create_session_ext(const char *name, const char *url, memset(&lsm, 0, sizeof(lsm)); lsm.cmd_type = LTTNG_CREATE_SESSION; - if (!strncmp(name, DEFAULT_SESSION_NAME, strlen(DEFAULT_SESSION_NAME))) { + if (!strncmp(name, DEFAULT_SESSION_NAME, strlen(DEFAULT_SESSION_NAME)) + && strlen(name) == strlen(DEFAULT_SESSION_NAME)) { ret = snprintf(lsm.session.name, sizeof(lsm.session.name), "%s-%s", name, datetime); if (ret < 0) { @@ -1625,7 +1626,7 @@ int _lttng_create_session_ext(const char *name, const char *url, lsm.u.uri.size = size; - if (uris[0].dtype != LTTNG_DST_PATH && strlen(uris[0].subdir) == 0) { + if (size > 0 && uris[0].dtype != LTTNG_DST_PATH && strlen(uris[0].subdir) == 0) { ret = snprintf(uris[0].subdir, sizeof(uris[0].subdir), "%s-%s", name, datetime); if (ret < 0) { @@ -1643,7 +1644,7 @@ int _lttng_create_session_ext(const char *name, const char *url, * or is still being extracted by the consumer(s) hence not ready to be used by * any readers. */ -int lttng_data_available(const char *session_name) +int lttng_data_pending(const char *session_name) { int ret; struct lttcomm_session_msg lsm; @@ -1652,7 +1653,7 @@ int lttng_data_available(const char *session_name) return -LTTNG_ERR_INVALID; } - lsm.cmd_type = LTTNG_DATA_AVAILABLE; + lsm.cmd_type = LTTNG_DATA_PENDING; copy_string(lsm.session.name, session_name, sizeof(lsm.session.name)); @@ -1680,3 +1681,11 @@ static void __attribute__((constructor)) init() /* Set socket for health check */ (void) set_health_socket_path(); } + +/* + * lib destructor + */ +static void __attribute__((destructor)) lttng_ctl_exit() +{ + free(tracing_group); +}