X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer-timer.c;h=7d000c145494fba7250e8901cd7d304e86936492;hb=d186e4cbbca201936132f3b6aad1710e35dec373;hp=cfbf443128696ed3cc9657732d6c28047c9169d2;hpb=5704917f6270a2d2fbdd03022bfb25132423d025;p=lttng-tools.git diff --git a/src/common/consumer/consumer-timer.c b/src/common/consumer/consumer-timer.c index cfbf44312..7d000c145 100644 --- a/src/common/consumer/consumer-timer.c +++ b/src/common/consumer/consumer-timer.c @@ -721,6 +721,7 @@ void monitor_timer(struct lttng_consumer_channel *channel) sample_positions_cb sample; get_consumed_cb get_consumed; get_produced_cb get_produced; + uint64_t lowest = 0, highest = 0, total_consumed = 0; assert(channel); @@ -744,11 +745,14 @@ void monitor_timer(struct lttng_consumer_channel *channel) abort(); } - ret = sample_channel_positions(channel, &msg.highest, &msg.lowest, - &msg.total_consumed, sample, get_consumed, get_produced); + ret = sample_channel_positions(channel, &highest, &lowest, + &total_consumed, sample, get_consumed, get_produced); if (ret) { return; } + msg.highest = highest; + msg.lowest = lowest; + msg.total_consumed = total_consumed; /* * Writes performed here are assumed to be atomic which is only