Commit | Line | Data |
---|---|---|
331744e3 | 1 | /* |
ab5be9fa MJ |
2 | * Copyright (C) 2011 Julien Desfossez <julien.desfossez@polymtl.ca> |
3 | * Copyright (C) 2011 Mathieu Desnoyers <mathieu.desnoyers@efficios.com> | |
4 | * Copyright (C) 2012 David Goulet <dgoulet@efficios.com> | |
331744e3 | 5 | * |
ab5be9fa | 6 | * SPDX-License-Identifier: GPL-2.0-only |
331744e3 | 7 | * |
331744e3 JD |
8 | */ |
9 | ||
10 | #ifndef CONSUMER_TIMER_H | |
11 | #define CONSUMER_TIMER_H | |
12 | ||
13 | #include <pthread.h> | |
14 | ||
15 | #include "consumer.h" | |
16 | ||
657d1bf1 SM |
17 | #ifdef __cplusplus |
18 | extern "C" { | |
19 | #endif | |
20 | ||
331744e3 JD |
21 | #define LTTNG_CONSUMER_SIG_SWITCH SIGRTMIN + 10 |
22 | #define LTTNG_CONSUMER_SIG_TEARDOWN SIGRTMIN + 11 | |
d3e2ba59 | 23 | #define LTTNG_CONSUMER_SIG_LIVE SIGRTMIN + 12 |
e9404c27 | 24 | #define LTTNG_CONSUMER_SIG_MONITOR SIGRTMIN + 13 |
13675d0e | 25 | #define LTTNG_CONSUMER_SIG_EXIT SIGRTMIN + 14 |
331744e3 JD |
26 | |
27 | #define CLOCKID CLOCK_MONOTONIC | |
28 | ||
29 | /* | |
30 | * Handle timer teardown race wrt memory free of private data by consumer | |
31 | * signals are handled by a single thread, which permits a synchronization | |
2b8f8754 MD |
32 | * point between handling of each signal. Internal lock ensures mutual |
33 | * exclusion. | |
331744e3 JD |
34 | */ |
35 | struct timer_signal_data { | |
36 | pthread_t tid; /* thread id managing signals */ | |
37 | int setup_done; | |
38 | int qs_done; | |
2b8f8754 | 39 | pthread_mutex_t lock; |
331744e3 JD |
40 | }; |
41 | ||
42 | void consumer_timer_switch_start(struct lttng_consumer_channel *channel, | |
e9404c27 | 43 | unsigned int switch_timer_interval_us); |
331744e3 | 44 | void consumer_timer_switch_stop(struct lttng_consumer_channel *channel); |
d3e2ba59 | 45 | void consumer_timer_live_start(struct lttng_consumer_channel *channel, |
e9404c27 | 46 | unsigned int live_timer_interval_us); |
d3e2ba59 | 47 | void consumer_timer_live_stop(struct lttng_consumer_channel *channel); |
e9404c27 JG |
48 | int consumer_timer_monitor_start(struct lttng_consumer_channel *channel, |
49 | unsigned int monitor_timer_interval_us); | |
50 | int consumer_timer_monitor_stop(struct lttng_consumer_channel *channel); | |
d3e2ba59 | 51 | void *consumer_timer_thread(void *data); |
73664f81 | 52 | int consumer_signal_init(void); |
331744e3 | 53 | |
c585821b MD |
54 | int consumer_flush_kernel_index(struct lttng_consumer_stream *stream); |
55 | int consumer_flush_ust_index(struct lttng_consumer_stream *stream); | |
56 | ||
e9404c27 JG |
57 | int consumer_timer_thread_get_channel_monitor_pipe(void); |
58 | int consumer_timer_thread_set_channel_monitor_pipe(int fd); | |
59 | ||
657d1bf1 SM |
60 | #ifdef __cplusplus |
61 | } | |
62 | #endif | |
63 | ||
331744e3 | 64 | #endif /* CONSUMER_TIMER_H */ |