diff --git a/src/rendezvous_server.rs b/src/rendezvous_server.rs index d8d9be8..dff45eb 100644 --- a/src/rendezvous_server.rs +++ b/src/rendezvous_server.rs @@ -47,7 +47,7 @@ enum Data { RelayServers(RelayServers), } -const REG_TIMEOUT: i32 = 30_000; +const REG_TIMEOUT: i64 = 30_000; type TcpStreamSink = SplitSink, Bytes>; type WsSink = SplitSink, tungstenite::Message>; enum Sink { @@ -697,7 +697,7 @@ impl RendezvousServer { if let Some(peer) = self.pm.get(&id).await { let (elapsed, peer_addr) = { let r = peer.read().await; - (r.last_reg_time.elapsed().as_millis() as i32, r.socket_addr) + (r.last_reg_time.elapsed().as_millis() as i64, r.socket_addr) }; if elapsed >= REG_TIMEOUT { let mut msg_out = RendezvousMessage::new(); @@ -790,7 +790,7 @@ impl RendezvousServer { let mut states = BytesMut::zeroed((peers.len() + 7) / 8); for (i, peer_id) in peers.iter().enumerate() { if let Some(peer) = self.pm.get_in_memory(peer_id).await { - let elapsed = peer.read().await.last_reg_time.elapsed().as_millis() as i32; + let elapsed = peer.read().await.last_reg_time.elapsed().as_millis() as i64; // bytes index from left to right let states_idx = i / 8; let bit_idx = 7 - i % 8;