}
}
-static int channel_monitor_pipe = -1;
+static int the_channel_monitor_pipe = -1;
/*
* Execute action on a timer switch.
struct lttng_consumer_channel *channel;
struct lttng_consumer_stream *stream;
struct lttng_ht_iter iter;
- const struct lttng_ht *ht = consumer_data.stream_per_chan_id_ht;
+ const struct lttng_ht *ht = the_consumer_data.stream_per_chan_id_ht;
const flush_index_cb flush_index =
ctx->type == LTTNG_CONSUMER_KERNEL ?
consumer_flush_kernel_index :
unsigned int timer_interval_us, int signal)
{
int ret = 0, delete_ret;
- struct sigevent sev;
+ struct sigevent sev = {};
struct itimerspec its;
assert(channel);
struct lttng_consumer_stream *stream;
bool empty_channel = true;
uint64_t high = 0, low = UINT64_MAX;
- struct lttng_ht *ht = consumer_data.stream_per_chan_id_ht;
+ struct lttng_ht *ht = the_consumer_data.stream_per_chan_id_ht;
*_total_consumed = 0;
return;
}
- switch (consumer_data.type) {
+ switch (the_consumer_data.type) {
case LTTNG_CONSUMER_KERNEL:
sample = lttng_kconsumer_sample_snapshot_positions;
get_consumed = lttng_kconsumer_get_consumed_snapshot;
int consumer_timer_thread_get_channel_monitor_pipe(void)
{
- return uatomic_read(&channel_monitor_pipe);
+ return uatomic_read(&the_channel_monitor_pipe);
}
int consumer_timer_thread_set_channel_monitor_pipe(int fd)
{
int ret;
- ret = uatomic_cmpxchg(&channel_monitor_pipe, -1, fd);
+ ret = uatomic_cmpxchg(&the_channel_monitor_pipe, -1, fd);
if (ret != -1) {
ret = -1;
goto end;