X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Fplugins%2Fctf%2Flttng-live%2Fdata-stream.cpp;h=82e4c316c7e7787c64880d97015bce94c5e50fa9;hb=2d5d8c7bb23c39ab8e62abc10d0843caac346ffd;hp=8a68650bdb5e341f4cec4a090e4caa25299194bf;hpb=0b68f2bcc2ee524fd201516ef0c9bec45e6529dc;p=babeltrace.git diff --git a/src/plugins/ctf/lttng-live/data-stream.cpp b/src/plugins/ctf/lttng-live/data-stream.cpp index 8a68650b..82e4c316 100644 --- a/src/plugins/ctf/lttng-live/data-stream.cpp +++ b/src/plugins/ctf/lttng-live/data-stream.cpp @@ -147,8 +147,7 @@ enum lttng_live_iterator_status lttng_live_lazy_msg_init(struct lttng_live_sessi fmt::ptr(self_msg_iter)); stream_iter->msg_iter = ctf_msg_iter_create(ctf_tc, lttng_live->max_query_size, medops, stream_iter, - self_msg_iter, stream_iter->logger) - .release(); + self_msg_iter, stream_iter->logger); if (!stream_iter->msg_iter) { BT_CPPLOGE_APPEND_CAUSE_SPEC(stream_iter->logger, "Failed to create CTF message iterator"); @@ -198,9 +197,9 @@ lttng_live_stream_iterator_create(struct lttng_live_session *session, uint64_t c struct ctf_trace_class *ctf_tc = ctf_metadata_decoder_borrow_ctf_trace_class(trace->metadata->decoder.get()); BT_ASSERT(!stream_iter->msg_iter); - stream_iter->msg_iter = ctf_msg_iter_create(ctf_tc, lttng_live->max_query_size, medops, - stream_iter, self_msg_iter, stream_iter->logger) - .release(); + stream_iter->msg_iter = + ctf_msg_iter_create(ctf_tc, lttng_live->max_query_size, medops, stream_iter, + self_msg_iter, stream_iter->logger); if (!stream_iter->msg_iter) { BT_CPPLOGE_APPEND_CAUSE_SPEC(stream_iter->logger, "Failed to create CTF message iterator"); @@ -243,9 +242,6 @@ void lttng_live_stream_iterator_destroy(struct lttng_live_stream_iterator *strea return; } - if (stream_iter->msg_iter) { - ctf_msg_iter_destroy(stream_iter->msg_iter); - } g_free(stream_iter->buf); if (stream_iter->name) { g_string_free(stream_iter->name, TRUE);