Skip to content

Commit 68f54f9

Browse files
committed
f Refactor disconnection bools
1 parent c6045a9 commit 68f54f9

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

lightning/src/ln/peer_handler.rs

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2809,11 +2809,10 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
28092809
peer.received_message_since_timer_tick = false;
28102810
break;
28112811
}
2812-
2813-
if (peer.awaiting_pong_timer_tick_intervals > 0 && !peer.received_message_since_timer_tick)
2814-
|| peer.awaiting_pong_timer_tick_intervals as u64 >
2815-
MAX_BUFFER_DRAIN_TICK_INTERVALS_PER_PEER as u64 * peers_lock.len() as u64
2816-
{
2812+
let not_recently_active = peer.awaiting_pong_timer_tick_intervals > 0 && !peer.received_message_since_timer_tick;
2813+
let reached_threshold_intervals = peer.awaiting_pong_timer_tick_intervals as u64 >
2814+
MAX_BUFFER_DRAIN_TICK_INTERVALS_PER_PEER as u64 * peers_lock.len() as u64;
2815+
if not_recently_active || reached_threshold_intervals {
28172816
descriptors_needing_disconnect.push(descriptor.clone());
28182817
break;
28192818
}

0 commit comments

Comments
 (0)