rustdesk/rustdesk-server
1
0
Fork 0
mirror of https://github.com/rustdesk/rustdesk-server.git synced 2025-07-03 08:15:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

test if udp/tcp share the same NAT port

Browse Source
This commit is contained in:
open-trade 2020-03-11 02:20:45 +08:00
parent defac1f338
commit 5e5d8927e2
3 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
Cargo.lock generated
View File

@ -159,6 +159,7 @@ dependencies = [
"env_logger 0.7.1 (registry+https://github.com/rust-lang/crates.io-index)", "env_logger 0.7.1 (registry+https://github.com/rust-lang/crates.io-index)",
"futures 0.3.4 (registry+https://github.com/rust-lang/crates.io-index)", "futures 0.3.4 (registry+https://github.com/rust-lang/crates.io-index)",
"log 0.4.8 (registry+https://github.com/rust-lang/crates.io-index)", "log 0.4.8 (registry+https://github.com/rust-lang/crates.io-index)",
"net2 0.2.33 (registry+https://github.com/rust-lang/crates.io-index)",
"protobuf 2.10.2 (registry+https://github.com/rust-lang/crates.io-index)", "protobuf 2.10.2 (registry+https://github.com/rust-lang/crates.io-index)",
"protobuf-codegen-pure 2.10.2 (registry+https://github.com/rust-lang/crates.io-index)", "protobuf-codegen-pure 2.10.2 (registry+https://github.com/rust-lang/crates.io-index)",
"tokio 0.2.13 (registry+https://github.com/rust-lang/crates.io-index)", "tokio 0.2.13 (registry+https://github.com/rust-lang/crates.io-index)",

2
libs/hbb_common

@ -1 +1 @@
Subproject commit 2cc3edf0f634adcb1e290c5c8b11bc21de38e763 Subproject commit 489ff100300235ef3b9e7820f1b13dadc75be5f8

9
src/rendezvous_server.rs
View File

@ -20,6 +20,15 @@ impl RendezvousServer {
let mut rs = Self { let mut rs = Self {
peer_map: PeerMap::new(), peer_map: PeerMap::new(),
}; };
/* // used to test if udp/tcp share the same NAT port, yes in my test
let addr = addr.to_string();
hbb_common::tokio::spawn(async {
let mut l = hbb_common::tokio::net::TcpListener::bind(addr).await.unwrap();
while let Ok((_, addr)) = l.accept().await {
log::debug!("Tcp peer {:?}", addr);
}
});
*/
while let Some(Ok((bytes, addr))) = socket.next().await { while let Some(Ok((bytes, addr))) = socket.next().await {
rs.handle_msg(&bytes, addr, &mut socket).await?; rs.handle_msg(&bytes, addr, &mut socket).await?;
} }