summaryrefslogtreecommitdiffstats
path: root/src/swarm/peer/handshake.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-26 18:51:01 +0100
committertv <tv@krebsco.de>2026-10-26 18:51:01 +0100
commit8d70536fd267e7ee730c390b6b47c03ddbef7df9 (patch)
treefbbd93242874765903ce7113fe78e3159f304a29 /src/swarm/peer/handshake.rs
parent8b7bf576d2b3ceb3e5b6cdae7a00989bebb3b4c4 (diff)
read stamps sync and lock free
Diffstat (limited to 'src/swarm/peer/handshake.rs')
-rw-r--r--src/swarm/peer/handshake.rs4
1 files changed, 2 insertions, 2 deletions
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,