X-Git-Url: https://git.liburcu.org/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer-timer.cpp;h=7f88a9712825de9151c4d082f6951ad11e81db1a;hb=cd9adb8b829564212158943a0d279bb35322ab30;hp=864ef6e9f7b57bf0be8cf44df0df1c8d9540c048;hpb=e665dfbce25215d5ec77ff03a279c7163b337db1;p=lttng-tools.git diff --git a/src/common/consumer/consumer-timer.cpp b/src/common/consumer/consumer-timer.cpp index 864ef6e9f..7f88a9712 100644 --- a/src/common/consumer/consumer-timer.cpp +++ b/src/common/consumer/consumer-timer.cpp @@ -393,7 +393,7 @@ static int consumer_channel_timer_start(timer_t *timer_id, its.it_interval.tv_sec = its.it_value.tv_sec; its.it_interval.tv_nsec = its.it_value.tv_nsec; - ret = timer_settime(*timer_id, 0, &its, NULL); + ret = timer_settime(*timer_id, 0, &its, nullptr); if (ret == -1) { PERROR("timer_settime"); goto error_destroy_timer; @@ -419,7 +419,7 @@ static int consumer_channel_timer_stop(timer_t *timer_id, int signal) } consumer_timer_signal_thread_qs(signal); - *timer_id = 0; + *timer_id = nullptr; end: return ret; } @@ -542,14 +542,14 @@ end: * Block the RT signals for the entire process. It must be called from the * consumer main before creating the threads */ -int consumer_signal_init(void) +int consumer_signal_init() { int ret; sigset_t mask; /* Block signal for entire process, so only our thread processes it. */ setmask(&mask); - ret = pthread_sigmask(SIG_BLOCK, &mask, NULL); + ret = pthread_sigmask(SIG_BLOCK, &mask, nullptr); if (ret) { errno = ret; PERROR("pthread_sigmask"); @@ -716,7 +716,7 @@ void sample_and_send_channel_buffer_stats(struct lttng_consumer_channel *channel } } -int consumer_timer_thread_get_channel_monitor_pipe(void) +int consumer_timer_thread_get_channel_monitor_pipe() { return uatomic_read(&the_channel_monitor_pipe); } @@ -761,7 +761,7 @@ void *consumer_timer_thread(void *data) setmask(&mask); CMM_STORE_SHARED(timer_signal.tid, pthread_self()); - while (1) { + while (true) { health_code_update(); health_poll_entry(); @@ -806,5 +806,5 @@ error_testpoint: end: health_unregister(health_consumerd); rcu_unregister_thread(); - return NULL; + return nullptr; }