X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer-timer.cpp;fp=src%2Fcommon%2Fconsumer%2Fconsumer-timer.cpp;h=8dae11fa2d5b465ccc3dab61f2aed7b948ab518a;hp=4e308383d22e5a1c22e7f9442c5b9a9dc87d1020;hb=319dcddc7409961e156af76666fe70d31baec55a;hpb=139a8d250fb18f8ffc95b0936f7285f7b484b72f

diff --git a/src/common/consumer/consumer-timer.cpp b/src/common/consumer/consumer-timer.cpp
index 4e308383d..8dae11fa2 100644
--- a/src/common/consumer/consumer-timer.cpp
+++ b/src/common/consumer/consumer-timer.cpp
@@ -645,9 +645,10 @@ void sample_and_send_channel_buffer_stats(struct lttng_consumer_channel *channel
 			consumer_timer_thread_get_channel_monitor_pipe();
 	struct lttcomm_consumer_channel_monitor_msg msg = {
 		.key = channel->key,
+		.session_id = channel->session_id,
 		.lowest = 0,
 		.highest = 0,
-		.total_consumed = 0,
+		.consumed_since_last_sample = 0,
 	};
 	sample_positions_cb sample;
 	get_consumed_cb get_consumed;
@@ -681,9 +682,10 @@ void sample_and_send_channel_buffer_stats(struct lttng_consumer_channel *channel
 	if (ret) {
 		return;
 	}
+
 	msg.highest = highest;
 	msg.lowest = lowest;
-	msg.total_consumed = total_consumed;
+	msg.consumed_since_last_sample = total_consumed - channel->last_consumed_size_sample_sent;
 
 	/*
 	 * Writes performed here are assumed to be atomic which is only
@@ -706,6 +708,7 @@ void sample_and_send_channel_buffer_stats(struct lttng_consumer_channel *channel
 		DBG("Sent channel monitoring sample for channel key %" PRIu64
 				", (highest = %" PRIu64 ", lowest = %" PRIu64 ")",
 				channel->key, msg.highest, msg.lowest);
+		channel->last_consumed_size_sample_sent = msg.consumed_since_last_sample;
 	}
 }