projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
consumerd: send a buffer static sample on flush command
[lttng-tools.git]
/
src
/
common
/
consumer
/
consumer-timer.cpp
diff --git
a/src/common/consumer/consumer-timer.cpp
b/src/common/consumer/consumer-timer.cpp
index f37bfa3506c0f08d6bc59f96ed6daf72736c0330..4e308383d22e5a1c22e7f9442c5b9a9dc87d1020 100644
(file)
--- a/
src/common/consumer/consumer-timer.cpp
+++ b/
src/common/consumer/consumer-timer.cpp
@@
-637,11
+637,8
@@
end:
return ret;
}
return ret;
}
-/*
- * Execute action on a monitor timer.
- */
-static
-void monitor_timer(struct lttng_consumer_channel *channel)
+/* Sample and send channel buffering statistics to the session daemon. */
+void sample_and_send_channel_buffer_stats(struct lttng_consumer_channel *channel)
{
int ret;
int channel_monitor_pipe =
{
int ret;
int channel_monitor_pipe =
@@
-787,7
+784,7
@@
void *consumer_timer_thread(void *data)
struct lttng_consumer_channel *channel;
channel = (lttng_consumer_channel *) info.si_value.sival_ptr;
struct lttng_consumer_channel *channel;
channel = (lttng_consumer_channel *) info.si_value.sival_ptr;
-
monitor_timer
(channel);
+
sample_and_send_channel_buffer_stats
(channel);
} else if (signr == LTTNG_CONSUMER_SIG_EXIT) {
LTTNG_ASSERT(CMM_LOAD_SHARED(consumer_quit));
goto end;
} else if (signr == LTTNG_CONSUMER_SIG_EXIT) {
LTTNG_ASSERT(CMM_LOAD_SHARED(consumer_quit));
goto end;
This page took
0.023393 seconds
and
4
git commands to generate.