projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix: consumerd: consumed size miscomputed during statistics sampling
[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 2ae7f0f73d1b2fdaffe59ed6b21b3814b78e8c22..70094ef4f98e30c5da46e9c8b087e3bd5dfdd7da 100644
(file)
--- a/
src/common/consumer/consumer-timer.cpp
+++ b/
src/common/consumer/consumer-timer.cpp
@@
-687,7
+687,8
@@
void sample_and_send_channel_buffer_stats(struct lttng_consumer_channel *channel
msg.highest = highest;
msg.lowest = lowest;
msg.highest = highest;
msg.lowest = lowest;
- msg.consumed_since_last_sample = total_consumed - channel->last_consumed_size_sample_sent;
+ msg.consumed_since_last_sample =
+ total_consumed - channel->consumed_size_as_of_last_sample_sent;
/*
* Writes performed here are assumed to be atomic which is only
/*
* Writes performed here are assumed to be atomic which is only
@@
-712,7
+713,7
@@
void sample_and_send_channel_buffer_stats(struct lttng_consumer_channel *channel
channel->key,
msg.highest,
msg.lowest);
channel->key,
msg.highest,
msg.lowest);
- channel->
last_consumed_size_sample_sent = msg.consumed_since_last_sample
;
+ channel->
consumed_size_as_of_last_sample_sent = total_consumed
;
}
}
}
}
This page took
0.023238 seconds
and
4
git commands to generate.