Skip to content

Commit f670a8a

Browse files
fix: delta/s no longer bottoms out at 0
1 parent bc68058 commit f670a8a

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

crescendo/src/tx_queue.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -71,8 +71,8 @@ impl TxQueue {
7171
let current_queue_len = self.queue_len();
7272
let added_per_second = (total_added - last_total_added) / measurement_interval.as_secs();
7373
let popped_per_second = (total_popped - last_total_popped) / measurement_interval.as_secs();
74-
let queue_growth =
75-
((current_queue_len.saturating_sub(last_queue_len)) as u64) / measurement_interval.as_secs();
74+
let delta_per_second =
75+
((current_queue_len as i64 - last_queue_len as i64) as f64 / measurement_interval.as_secs_f64()) as i64;
7676

7777
// Adjust rate limit based on total popped transactions and thresholds.
7878
let rate_config = &config::get().rate_limiting;
@@ -95,7 +95,7 @@ impl TxQueue {
9595
"[*] TxQueue +/s: {}, -/s: {}, Δ/s: {}, Length: {}, Rate limit: {}/s",
9696
added_per_second.separate_with_commas(),
9797
popped_per_second.separate_with_commas(),
98-
queue_growth.separate_with_commas(),
98+
delta_per_second.separate_with_commas(),
9999
current_queue_len.separate_with_commas(),
100100
self.rate_limiter.refill_amount().separate_with_commas()
101101
);

0 commit comments

Comments
 (0)