X-Git-Url: http://git.lttng.org./?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer-timer.hpp;h=50025d727cf98db138f394c6aef78835417561f4;hb=c661f2f4c022314efcdc76b18f084cb42275370b;hp=3445ed57fd1fd2399824912e36ee135a88c26695;hpb=c9e313bc594f40a86eed237dce222c0fc99c957f;p=lttng-tools.git diff --git a/src/common/consumer/consumer-timer.hpp b/src/common/consumer/consumer-timer.hpp index 3445ed57f..50025d727 100644 --- a/src/common/consumer/consumer-timer.hpp +++ b/src/common/consumer/consumer-timer.hpp @@ -10,15 +10,15 @@ #ifndef CONSUMER_TIMER_H #define CONSUMER_TIMER_H -#include - #include "consumer.hpp" -#define LTTNG_CONSUMER_SIG_SWITCH SIGRTMIN + 10 -#define LTTNG_CONSUMER_SIG_TEARDOWN SIGRTMIN + 11 -#define LTTNG_CONSUMER_SIG_LIVE SIGRTMIN + 12 -#define LTTNG_CONSUMER_SIG_MONITOR SIGRTMIN + 13 -#define LTTNG_CONSUMER_SIG_EXIT SIGRTMIN + 14 +#include + +#define LTTNG_CONSUMER_SIG_SWITCH ((SIGRTMIN + 10)) +#define LTTNG_CONSUMER_SIG_TEARDOWN ((SIGRTMIN + 11)) +#define LTTNG_CONSUMER_SIG_LIVE ((SIGRTMIN + 12)) +#define LTTNG_CONSUMER_SIG_MONITOR ((SIGRTMIN + 13)) +#define LTTNG_CONSUMER_SIG_EXIT ((SIGRTMIN + 14)) #define CLOCKID CLOCK_MONOTONIC @@ -29,28 +29,28 @@ * exclusion. */ struct timer_signal_data { - pthread_t tid; /* thread id managing signals */ + pthread_t tid; /* thread id managing signals */ int setup_done; int qs_done; pthread_mutex_t lock; }; void consumer_timer_switch_start(struct lttng_consumer_channel *channel, - unsigned int switch_timer_interval_us); + unsigned int switch_timer_interval_us); void consumer_timer_switch_stop(struct lttng_consumer_channel *channel); void consumer_timer_live_start(struct lttng_consumer_channel *channel, - unsigned int live_timer_interval_us); + unsigned int live_timer_interval_us); void consumer_timer_live_stop(struct lttng_consumer_channel *channel); int consumer_timer_monitor_start(struct lttng_consumer_channel *channel, - unsigned int monitor_timer_interval_us); + unsigned int monitor_timer_interval_us); int consumer_timer_monitor_stop(struct lttng_consumer_channel *channel); void *consumer_timer_thread(void *data); -int consumer_signal_init(void); +int consumer_signal_init(); int consumer_flush_kernel_index(struct lttng_consumer_stream *stream); int consumer_flush_ust_index(struct lttng_consumer_stream *stream); -int consumer_timer_thread_get_channel_monitor_pipe(void); +int consumer_timer_thread_get_channel_monitor_pipe(); int consumer_timer_thread_set_channel_monitor_pipe(int fd); #endif /* CONSUMER_TIMER_H */