hongshaorou/rustdesk
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

set_nodelay

Browse Source
This commit is contained in:
rustdesk 2022-01-23 20:53:55 +08:00
parent 372b715162
commit bf578e768b
2 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libs/hbb_common/src/tcp.rs
View File

@ -85,6 +85,7 @@ impl FramedStream {
new_socket(local_addr, true)?.connect(remote_addr), new_socket(local_addr, true)?.connect(remote_addr),
) )
.await??; .await??;
stream.set_nodelay(true).ok();
let addr = stream.local_addr()?; let addr = stream.local_addr()?;
return Ok(Self( return Ok(Self(
Framed::new(DynTcpStream(Box::new(stream)), BytesCodec::new()), Framed::new(DynTcpStream(Box::new(stream)), BytesCodec::new()),
@ -114,6 +115,7 @@ impl FramedStream {
if let Some(proxy) = proxy.to_proxy_addrs().next().await { if let Some(proxy) = proxy.to_proxy_addrs().next().await {
let stream = let stream =
super::timeout(ms_timeout, new_socket(local, true)?.connect(proxy?)).await??; super::timeout(ms_timeout, new_socket(local, true)?.connect(proxy?)).await??;
stream.set_nodelay(true).ok();
let stream = if username.trim().is_empty() { let stream = if username.trim().is_empty() {
super::timeout( super::timeout(
ms_timeout, ms_timeout,

1
src/server.rs
View File

@ -75,6 +75,7 @@ async fn accept_connection_(server: ServerPtr, socket: Stream, secure: bool) ->
let listener = new_listener(local_addr, true).await?; let listener = new_listener(local_addr, true).await?;
log::info!("Server listening on: {}", &listener.local_addr()?); log::info!("Server listening on: {}", &listener.local_addr()?);
if let Ok((stream, addr)) = timeout(CONNECT_TIMEOUT, listener.accept()).await? { if let Ok((stream, addr)) = timeout(CONNECT_TIMEOUT, listener.accept()).await? {
stream.set_nodelay(true).ok();
let stream_addr = stream.local_addr()?; let stream_addr = stream.local_addr()?;
create_tcp_connection(server, Stream::from(stream, stream_addr), addr, secure).await?; create_tcp_connection(server, Stream::from(stream, stream_addr), addr, secure).await?;
} }