X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer.h;h=3af7db9136f3b011eef851397a2747ac86878ce2;hp=c7ef3fb38317a795b5d9f7bc394a708619108966;hb=fb83fe64f250bec7416f18891a8264450c61ead3;hpb=53e367f936beb2f9a1f49f6a2920c2f58bcb08d7 diff --git a/src/common/consumer/consumer.h b/src/common/consumer/consumer.h index c7ef3fb38..3af7db913 100644 --- a/src/common/consumer/consumer.h +++ b/src/common/consumer/consumer.h @@ -58,6 +58,8 @@ enum lttng_consumer_command { LTTNG_CONSUMER_SNAPSHOT_CHANNEL, LTTNG_CONSUMER_SNAPSHOT_METADATA, LTTNG_CONSUMER_STREAMS_SENT, + LTTNG_CONSUMER_DISCARDED_EVENTS, + LTTNG_CONSUMER_LOST_PACKETS, }; /* State of each fd in consumer */ @@ -211,6 +213,10 @@ struct lttng_consumer_channel { int nr_stream_fds; char root_shm_path[PATH_MAX]; char shm_path[PATH_MAX]; + /* Total number of discarded events for that channel. */ + uint64_t discarded_events; + /* Total number of missed packets due to overwriting (overwrite). */ + uint64_t lost_packets; }; /* @@ -351,6 +357,13 @@ struct lttng_consumer_stream { * to the channel. */ uint64_t ust_metadata_pushed; + /* + * Copy of the last discarded event value to detect the overflow of + * the counter. + */ + uint64_t last_discarded_events; + /* Copy of the sequence number of the last packet extracted. */ + uint64_t last_sequence_number; /* * FD of the index file for this stream. */