1. if peers disconnected before stop session, may crash at the assert.
2. bind_device flag should take effect on manual connector.
This commit is contained in:
Sijie.Sun
2025-01-12 00:16:38 +08:00
committed by GitHub
parent bb0ccca3e5
commit 9d76b86f49
2 changed files with 8 additions and 7 deletions
+8 -6
View File
@@ -297,12 +297,14 @@ impl ManualConnectorManager {
connector.lock().await.set_ip_version(ip_version); connector.lock().await.set_ip_version(ip_version);
set_bind_addr_for_peer_connector( if data.global_ctx.config.get_flags().bind_device {
connector.lock().await.as_mut(), set_bind_addr_for_peer_connector(
ip_version == IpVersion::V4, connector.lock().await.as_mut(),
&ip_collector, ip_version == IpVersion::V4,
) &ip_collector,
.await; )
.await;
}
data.global_ctx.issue_event(GlobalCtxEvent::Connecting( data.global_ctx.issue_event(GlobalCtxEvent::Connecting(
connector.lock().await.remote_url().clone(), connector.lock().await.remote_url().clone(),
-1
View File
@@ -1739,7 +1739,6 @@ impl RouteSessionManager {
continue; continue;
} }
let _ = self.stop_session(*peer_id); let _ = self.stop_session(*peer_id);
assert_ne!(Some(*peer_id), cur_dst_peer_id_to_initiate);
} }
} }