X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fstream.h;h=c88e725c012955473de8dc50df6d707b9ff35537;hb=1c9bd75bb3b9042c5ba1221c344af8b80b9dcaaf;hp=b8d14ecfb8cb0d07b40553456bc0fae86a7d5f4e;hpb=c35f9726a22f1d93e14589688d830efccda196f3;p=lttng-tools.git diff --git a/src/bin/lttng-relayd/stream.h b/src/bin/lttng-relayd/stream.h index b8d14ecfb..c88e725c0 100644 --- a/src/bin/lttng-relayd/stream.h +++ b/src/bin/lttng-relayd/stream.h @@ -44,10 +44,15 @@ struct relay_stream_rotation { bool data_rotated; bool index_rotated; /* - * Sequence number of the first packet of the new trace chunk to which - * the stream is rotating. + * Packet sequence number of the first packet of the new trace chunk to + * which the stream is rotating. */ - uint64_t seq_num; + uint64_t packet_seq_num; + /* + * Monotonically increasing previous network sequence number of first + * data packet of the new trace chunk to which the stream is rotating. + */ + uint64_t prev_data_net_seq; struct lttng_trace_chunk *next_trace_chunk; }; @@ -111,6 +116,12 @@ struct relay_stream { */ uint64_t index_received_seqcount; + /* + * Packet sequence number of the last received packet index. + * Only populated when interacting with CTF_INDEX 1.1+. + */ + LTTNG_OPTIONAL(uint64_t) received_packet_seq_num; + /* * Tracefile array is an index of the stream trace files, * indexed by position. It allows keeping track of the oldest @@ -164,6 +175,8 @@ struct relay_stream { struct cds_list_head recv_node; /* Protected by session lock. */ bool published; + /* Notified viewer that no new metadata is available. */ + bool no_new_metadata_notified; /* * Node of stream within global stream hash table. */