|
|
@@ -759,15 +759,11 @@ impl RendezvousServer {
|
|
759
|
759
|
) -> ResultType<()> {
|
|
760
|
760
|
let mut states = BytesMut::zeroed((peers.len() + 7) / 8);
|
|
761
|
761
|
for i in 0..peers.len() {
|
|
762
|
|
- let peer_id = &peers[i];
|
|
763
|
|
- // bytes index from left to right
|
|
764
|
|
- let states_idx = i / 8;
|
|
765
|
|
- let bit_idx = 7 - i % 8;
|
|
766
|
|
- if let Some(peer) = self.pm.get_in_memory(&peer_id).await {
|
|
767
|
|
- let (elapsed, _) = {
|
|
768
|
|
- let r = peer.read().await;
|
|
769
|
|
- (r.last_reg_time.elapsed().as_millis() as i32, r.socket_addr)
|
|
770
|
|
- };
|
|
|
762
|
+ if let Some(peer) = self.pm.get_in_memory(&peers[i]).await {
|
|
|
763
|
+ let elapsed = peer.read().await.last_reg_time.elapsed().as_millis() as i32;
|
|
|
764
|
+ // bytes index from left to right
|
|
|
765
|
+ let states_idx = i / 8;
|
|
|
766
|
+ let bit_idx = 7 - i % 8;
|
|
771
|
767
|
if elapsed < REG_TIMEOUT {
|
|
772
|
768
|
states[states_idx] |= 0x01 << bit_idx;
|
|
773
|
769
|
}
|