From 3b75a1f2d5226a056e4e14a08c37edfac7b78336 Mon Sep 17 00:00:00 2001 From: Francis Deslauriers Date: Mon, 9 Sep 2019 21:27:24 -0400 Subject: [PATCH] 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 --- src/plugins/ctf/lttng-live/data-stream.c | 10 ++++++++++ 1 file changed, 10 insertions(+) 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) { -- 2.34.1