We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b4290c2 commit 9563307Copy full SHA for 9563307
1 file changed
src/timer_loop.rs
@@ -56,7 +56,9 @@ impl<K: SandClockInsertion + Debug> TimerLoop<K> {
56
57
std::thread::spawn(move || {
58
let mut expired_queue: Vec<InsertSync<K>> = vec![];
59
- loop {
+
60
+ let now = Instant::now();
61
+loop {
62
let mut conn_it = map.iter_mut();
63
'inner_it: loop {
64
if let Some(mut connection_status_ref) = conn_it.next() {
@@ -68,7 +70,7 @@ impl<K: SandClockInsertion + Debug> TimerLoop<K> {
68
70
let last_updated_instant =
69
71
connection_status.time_out_info().get_last_instant_update();
72
- let now = Instant::now();
73
74
75
if now.duration_since(last_updated_instant) >= time_out {
76
let key = connection_status_ref.key().clone();
0 commit comments