X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fconsumer.h;h=18d989809d4fed93823675df2c10abd338bc018c;hp=73f113d0aca6fd8f4d33e2ba60cfe9bedd398d9f;hb=b31610f2294a6a827fa2d0d19d71199567db8dc5;hpb=6addfa379ee608b20cfe5e15d135bcb6a9724e90 diff --git a/src/bin/lttng-sessiond/consumer.h b/src/bin/lttng-sessiond/consumer.h index 73f113d0a..18d989809 100644 --- a/src/bin/lttng-sessiond/consumer.h +++ b/src/bin/lttng-sessiond/consumer.h @@ -18,7 +18,7 @@ #ifndef _CONSUMER_H #define _CONSUMER_H -#include +#include #include #include #include @@ -153,6 +153,9 @@ struct consumer_output { * index. The relayd sockets are index with it on the consumer side. */ uint64_t net_seq_index; + /* Store the relay protocol in use if the session is remote. */ + uint32_t relay_major_version; + uint32_t relay_minor_version; /* * Subdirectory path name used for both local and network consumer. @@ -281,6 +284,10 @@ int consumer_push_metadata(struct consumer_socket *socket, uint64_t metadata_key, char *metadata_str, size_t len, size_t target_offset); int consumer_flush_channel(struct consumer_socket *socket, uint64_t key); +int consumer_get_discarded_events(uint64_t session_id, uint64_t channel_key, + struct consumer_output *consumer, uint64_t *discarded); +int consumer_get_lost_packets(uint64_t session_id, uint64_t channel_key, + struct consumer_output *consumer, uint64_t *lost); /* Snapshot command. */ int consumer_snapshot_channel(struct consumer_socket *socket, uint64_t key,