From: Francis Deslauriers Date: Tue, 10 Sep 2019 01:27:24 +0000 (-0400) Subject: Fix: src.ctf.lttng-live: no stream beginning/end messages X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=commitdiff_plain;h=3b75a1f2d5226a056e4e14a08c37edfac7b78336 Fix: src.ctf.lttng-live: no stream beginning/end messages Issue ===== `src.ctf.lttng-live` components don't emit stream beginning and end messages. This is due to the `bt_msg_iter::emit_stream_begin_msg` field being set to false at allocation time. Solution ======== Set it to true right after the allocation. Signed-off-by: Francis Deslauriers Change-Id: Iae6b174e10070b32a877bb9ba7c1e637491ee15d Reviewed-on: https://review.lttng.org/c/babeltrace/+/2022 Tested-by: jenkins Reviewed-by: Philippe Proulx --- diff --git a/src/plugins/ctf/lttng-live/data-stream.c b/src/plugins/ctf/lttng-live/data-stream.c index 04496b81..371d0197 100644 --- a/src/plugins/ctf/lttng-live/data-stream.c +++ b/src/plugins/ctf/lttng-live/data-stream.c @@ -172,6 +172,11 @@ enum lttng_live_iterator_status lttng_live_lazy_msg_init( if (!stream_iter->msg_iter) { goto error; } + + bt_msg_iter_set_emit_stream_end_message( + stream_iter->msg_iter, true); + bt_msg_iter_set_emit_stream_beginning_message( + stream_iter->msg_iter, true); } } @@ -232,6 +237,11 @@ struct lttng_live_stream_iterator *lttng_live_stream_iterator_create( if (!stream_iter->msg_iter) { goto error; } + + bt_msg_iter_set_emit_stream_end_message( + stream_iter->msg_iter, true); + bt_msg_iter_set_emit_stream_beginning_message( + stream_iter->msg_iter, true); } stream_iter->buf = g_new0(uint8_t, lttng_live->max_query_size); if (!stream_iter->buf) {