studio/tuwunel
2
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Fix missing counter retirements (51931de94c).

Browse Source 
Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk
2025-07-30 21:27:30 +00:00
parent 0b15ab2006
commit f3f23ee7ee
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/core/utils/two_phase_counter.rs
View File

@@ -152,9 +152,15 @@ impl<F: Fn(u64) -> Result + Sync> State<F> {
debug_assert!(removed == id, "sequence number removed must match id"); debug_assert!(removed == id, "sequence number removed must match id");
if index == 0 { // release only occurs when the oldest value retires
(self.release)(id).expect("release callback should not error"); if index != 0 {
return;
} }
// release occurs for the maximum retired value
let release = if self.pending.is_empty() { self.dispatched } else { id };
(self.release)(release).expect("release callback should not error");
} }
/// Calculate the retired sequence number, one less than the lowest pending /// Calculate the retired sequence number, one less than the lowest pending