We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7f237b7 commit 55664f1Copy full SHA for 55664f1
src/task/blocking.rs
@@ -60,10 +60,10 @@ lazy_static! {
60
61
fn calculate_dispatch_frequency() {
62
// Calculate current message processing rate here
63
- let previous_freq = FREQUENCY.fetch_sub(1, Ordering::Relaxed);
+ let current_freq = FREQUENCY.fetch_sub(1, Ordering::Relaxed);
64
let avr_freq = AVR_FREQUENCY.load(Ordering::Relaxed);
65
let current_pool_size = CURRENT_POOL_SIZE.load(Ordering::Relaxed);
66
- let frequency = (avr_freq as f64 + previous_freq as f64 / current_pool_size as f64) as u64;
+ let frequency = (avr_freq as f64 + current_freq as f64 / current_pool_size as f64) as u64;
67
AVR_FREQUENCY.store(frequency, Ordering::Relaxed);
68
69
// Adapt the thread count of pool
0 commit comments