X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer.h;h=4cf6e910d5ef44ad2ba1967b897458632aca9e10;hp=fa503ea111836c18335eb7863123275daa2a6edc;hb=10a5031171c7bca5b4498c871b119e5a88b6a3fb;hpb=618a6a28c0956fc6829c165a39ffec97f239096c diff --git a/src/common/consumer.h b/src/common/consumer.h index fa503ea11..4cf6e910d 100644 --- a/src/common/consumer.h +++ b/src/common/consumer.h @@ -140,12 +140,6 @@ struct lttng_consumer_channel { */ struct stream_list streams; - /* - * List of streams in no monitor mode for this channel. Used ONLY for - * snapshots recording. - */ - struct stream_list stream_no_monitor_list; - /* * Set if the channel is metadata. We keep a reference to the stream * because we have to flush data once pushed by the session daemon. For a @@ -265,9 +259,6 @@ struct lttng_consumer_stream { /* On-disk circular buffer */ uint64_t tracefile_size_current; uint64_t tracefile_count_current; - - /* Node for the no monitor stream list in a channel. */ - struct cds_list_head no_monitor_node; }; /* @@ -512,6 +503,8 @@ void consumer_del_channel(struct lttng_consumer_channel *channel); struct consumer_relayd_sock_pair *consumer_allocate_relayd_sock_pair( uint64_t net_seq_idx); struct consumer_relayd_sock_pair *consumer_find_relayd(uint64_t key); +int consumer_send_relayd_stream(struct lttng_consumer_stream *stream, char *path); +void close_relayd_stream(struct lttng_consumer_stream *stream); struct lttng_consumer_channel *consumer_find_channel(uint64_t key); int consumer_handle_stream_before_relayd(struct lttng_consumer_stream *stream, size_t data_size);