X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng%2Fcommands%2Fdestroy.c;h=02c7139c3547e4e9a4dff2516e223597081faa76;hb=18d0885089aafd5665cea5fcff8a7a467b6ff37d;hp=aad4bdd23f07db2ac8a9b53eaab6044a0abdf54e;hpb=38b4ef1b199ddb15db78774a39e9c524ca7e2d24;p=lttng-tools.git diff --git a/src/bin/lttng/commands/destroy.c b/src/bin/lttng/commands/destroy.c index aad4bdd23..02c7139c3 100644 --- a/src/bin/lttng/commands/destroy.c +++ b/src/bin/lttng/commands/destroy.c @@ -35,6 +35,12 @@ static char *opt_session_name; static int opt_destroy_all; static int opt_no_wait; +#ifdef LTTNG_EMBED_HELP +static const char help_msg[] = +#include +; +#endif + /* Mi writer */ static struct mi_writer *writer; @@ -70,8 +76,8 @@ static int destroy_session(struct lttng_session *session) } session_was_stopped = ret == -LTTNG_ERR_TRACE_ALREADY_STOPPED; if (!opt_no_wait) { - _MSG("Waiting for data availability"); - fflush(stdout); + bool printed_wait_msg = false; + do { ret = lttng_data_pending(session->name); if (ret < 0) { @@ -84,12 +90,20 @@ static int destroy_session(struct lttng_session *session) * returned value indicates availability. */ if (ret) { + if (!printed_wait_msg) { + _MSG("Waiting for data availability"); + fflush(stdout); + } + + printed_wait_msg = true; usleep(DEFAULT_DATA_AVAILABILITY_WAIT_TIME); _MSG("."); fflush(stdout); } } while (ret != 0); - MSG(""); + if (printed_wait_msg) { + MSG(""); + } } if (!session_was_stopped) { /* @@ -218,7 +232,8 @@ int cmd_destroy(int argc, const char **argv) /* Recuperate all sessions for further operation */ count = lttng_list_sessions(&sessions); if (count < 0) { - command_ret = count; + ERR("%s", lttng_strerror(count)); + command_ret = CMD_ERROR; success = 0; goto mi_closing; }