From 8d70536fd267e7ee730c390b6b47c03ddbef7df9 Mon Sep 17 00:00:00 2001 From: tv Date: Mon, 26 Oct 2026 18:51:01 +0100 Subject: read stamps sync and lock free --- src/swarm/peer/handshake.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'src/swarm/peer/handshake.rs') diff --git a/src/swarm/peer/handshake.rs b/src/swarm/peer/handshake.rs index f08929a..7e494c6 100644 --- a/src/swarm/peer/handshake.rs +++ b/src/swarm/peer/handshake.rs @@ -118,7 +118,7 @@ async fn transmit_hello(state: &AppState, peer: &str) -> Result<()> { .as_ref() .map(|key| key.hello_tag(swarm_id.as_deref().unwrap_or(""), state.local_id(), peer)) .unwrap_or_default(); - let (epoch, epoch_seq) = state.epoch_stamp().await; + let (epoch, epoch_seq) = state.epoch_stamp(); // Retries repeat the handshake's number. let handshake = match state.get_peer_state(peer).await { Some(peer_state) => peer_state.lock().await.handshake, @@ -209,7 +209,7 @@ pub(super) async fn send_hello_reply( .map(|key| key.hello_reply_tag(&swarm_id, state.local_id(), peer)) .unwrap_or_default(); let ready = state.is_ready().await; - let (epoch, epoch_seq) = state.epoch_stamp().await; + let (epoch, epoch_seq) = state.epoch_stamp(); let reply = transport::HelloReply { swarm_id, peers, -- cgit v1.3.1