#define LTTNG_LIVE_LOGD_STREAM_ITER(live_stream_iter) \
do { \
BT_COMP_LOGD("Live stream iterator state=%s, " \
- "last-inact-ts-is-set=%d, last-inact-ts-value=%" PRId64 "), " \
- "curr-inact-ts %" PRId64, \
+ "last-inact-ts-is-set=%d, last-inact-ts-value=%" PRId64 ", " \
+ "curr-inact-ts=%" PRId64, \
lttng_live_stream_state_string(live_stream_iter->state), \
live_stream_iter->last_inactivity_ts.is_set, \
live_stream_iter->last_inactivity_ts.value, \
BT_COMP_LOGD("Emitting inactivity message for stream: ctf-stream-id=%" PRIu64
", viewer-stream-id=%" PRIu64 ", timestamp=%" PRIu64,
- stream_iter->ctf_stream_class_id,
+ stream_iter->ctf_stream_class_id.value,
stream_iter->viewer_stream_id, timestamp);
msg = bt_message_message_iterator_inactivity_create(
goto retry;
}
- BT_COMP_LOGD("Returning from advancing live stream iterator: status=%s"
+ BT_COMP_LOGD("Returning from advancing live stream iterator: status=%s, "
"stream-name=\"%s\", viewer-stream-id=%" PRIu64,
lttng_live_iterator_status_string(live_status),
stream_iter->name->str, stream_iter->viewer_stream_id);
BT_ASSERT_DBG(adjusted_message);
stream_iter->current_msg = adjusted_message;
stream_iter->current_msg_ts_ns = last_inactivity_ts_ns;
+ bt_message_put_ref(late_msg);
end:
return stream_iter_status;
BT_ASSERT_DBG(msg);
- BT_COMP_LOGD("Live stream iterator returned message: msg-type=%s"
+ BT_COMP_LOGD("Live stream iterator returned message: msg-type=%s, "
"stream-name=\"%s\", viewer-stream-id=%" PRIu64,
bt_common_message_type_string(bt_message_get_type(msg)),
stream_iter->name->str, stream_iter->viewer_stream_id);