X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=formats%2Flttng-live%2Flttng-live-comm.c;h=3970ac22ee6ed43fa33dae4664061cc478811836;hp=cd4217f187909ebbb7d6500b05673d01785d2d96;hb=85bb466398bbf32d8334066011bfe7be7ba71d8a;hpb=4d4bf6eb5529937cbbb2b4e891a6207edb1a26da diff --git a/formats/lttng-live/lttng-live-comm.c b/formats/lttng-live/lttng-live-comm.c index cd4217f1..3970ac22 100644 --- a/formats/lttng-live/lttng-live-comm.c +++ b/formats/lttng-live/lttng-live-comm.c @@ -1467,8 +1467,9 @@ void lttng_live_read(struct lttng_live_ctx *ctx) sout = container_of(td_write, struct ctf_text_stream_pos, trace_descriptor); - if (!sout->parent.event_cb) + if (!sout->parent.event_cb) { goto end_free; + } ret = lttng_live_create_viewer_session(ctx); if (ret < 0) { @@ -1495,13 +1496,16 @@ void lttng_live_read(struct lttng_live_ctx *ctx) int flags; while (!ctx->session->stream_count) { - if (ctx->session_ids->len == 0) + if (ctx->session_ids->len == 0) { goto end_free; + } ret = ask_new_streams(ctx); - if (ret < 0) + if (ret < 0) { goto end_free; - if (!ctx->session->stream_count) + } + if (!ctx->session->stream_count) { (void) poll(NULL, 0, ACTIVE_POLL_DELAY); + } } g_hash_table_foreach(ctx->session->ctf_traces, add_traces,