X-Git-Url: http://git.lttng.org./?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer.h;h=84ef2719d47e55eb7abc8626cdf37b3a11da525c;hb=ad0b0d2321fc4e798a2aaf7c17568e3afdf41834;hp=8d7e1d0a46d0a678685d7bac209e477ffa6c8bee;hpb=a4baae1b0463bc4ce65c2a458c4a941e7fabc594;p=lttng-tools.git diff --git a/src/common/consumer.h b/src/common/consumer.h index 8d7e1d0a4..84ef2719d 100644 --- a/src/common/consumer.h +++ b/src/common/consumer.h @@ -512,7 +512,7 @@ struct lttng_consumer_global_data { /* * Init consumer data structures. */ -void lttng_consumer_init(void); +int lttng_consumer_init(void); /* * Set the error socket for communication with a session daemon. @@ -622,6 +622,8 @@ ssize_t lttng_consumer_on_read_subbuffer_splice( int lttng_consumer_take_snapshot(struct lttng_consumer_stream *stream); int lttng_consumer_get_produced_snapshot(struct lttng_consumer_stream *stream, unsigned long *pos); +int lttng_ustconsumer_get_wakeup_fd(struct lttng_consumer_stream *stream); +int lttng_ustconsumer_close_wakeup_fd(struct lttng_consumer_stream *stream); void *consumer_thread_metadata_poll(void *data); void *consumer_thread_data_poll(void *data); void *consumer_thread_sessiond_poll(void *data);