src.ctf.lttng-live: use optional pattern for `ctf_stream_class_id`

[babeltrace.git] / src / plugins / ctf / lttng-live / lttng-live.h

diff --git a/src/plugins/ctf/lttng-live/lttng-live.h b/src/plugins/ctf/lttng-live/lttng-live.h
index 1f0d3f7da8f56543ca5006d5e2c5786c088ae467..d0d5b153385866683bbf9c8aad8d164858192fa5 100644 (file)
--- a/src/plugins/ctf/lttng-live/lttng-live.h
+++ b/src/plugins/ctf/lttng-live/lttng-live.h
@@ -65,7 +65,10 @@ struct lttng_live_stream_iterator {
 
        uint64_t viewer_stream_id;
 
-       uint64_t ctf_stream_class_id;
+       struct {
+               bool is_set;
+               uint64_t value;
+       } ctf_stream_class_id;
 
        /* base offset in current index. */
        uint64_t base_offset;
@@ -78,7 +81,10 @@ struct lttng_live_stream_iterator {
         * Clock Snapshot value of the last message iterator inactivity message
         * sent downstream.
         */
-       uint64_t last_inactivity_ts;
+       struct {
+               bool is_set;
+               uint64_t value;
+       } last_inactivity_ts;
 
        /*
         * Clock Snapshot value of the current message iterator inactivity
@@ -328,4 +334,9 @@ enum ctf_msg_iter_medium_status lttng_live_get_stream_bytes(
 
 bool lttng_live_graph_is_canceled(struct lttng_live_msg_iter *msg_iter);
 
+BT_HIDDEN
+void lttng_live_stream_iterator_set_state(
+               struct lttng_live_stream_iterator *stream_iter,
+               enum lttng_live_stream_state new_state);
+
 #endif /* BABELTRACE_PLUGIN_CTF_LTTNG_LIVE_H */