From df17d9b1da6353eadf4fa34cabc41bd43f4edc1c Mon Sep 17 00:00:00 2001 From: holger krekel Date: Sat, 18 May 2024 18:25:32 +0200 Subject: [PATCH] Revert "keep lock longer" This reverts commit b501ab15320d6528dd61da45617665b6ba0af56e. --- src/peer_channels.rs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/peer_channels.rs b/src/peer_channels.rs index 5c257e7ea..f88067b3d 100644 --- a/src/peer_channels.rs +++ b/src/peer_channels.rs @@ -90,7 +90,6 @@ impl Iroh { 0 }; - let mut channels = self.iroh_channels.write().await; let peers = get_iroh_gossip_peers(ctx, msg_id).await?; info!( ctx, @@ -116,7 +115,10 @@ impl Iroh { .join(topic, peers.into_iter().map(|addr| addr.node_id).collect()) .await?; - channels.insert(topic, ChannelState::new(seq, subscribe_loop)); + self.iroh_channels + .write() + .await + .insert(topic, ChannelState::new(seq, subscribe_loop)); Ok(Some(connect_future)) }