hatter/fast-socks
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

feat: update fast socks

Browse Source
This commit is contained in:
Hatter Jiang
2022-06-10 22:43:50 +08:00
parent 6f03f7f6f0
commit 3c79836afc
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/server.rs
View File

@@ -661,8 +661,8 @@ async fn transfer<I, O>(inbound: I, outbound: O) -> Result<()>
let (mut ri, mut wi) = tokio::io::split(inbound); let (mut ri, mut wi) = tokio::io::split(inbound);
let (mut ro, mut wo) = tokio::io::split(outbound); let (mut ro, mut wo) = tokio::io::split(outbound);
// IO copy timeout 12 HOURS // IO copy timeout 12 HOURS
let tcp_io_copy_timeout = Duration::from_secs(12 * 3600); let tcp_io_copy_timeout = Duration::from_secs(6 * 3600);
let client_to_server = async { let client_to_server = async move {
// let copy_result = time::timeout(tcp_io_copy_timeout, tokio::io::copy(&mut ri, &mut wo)); // let copy_result = time::timeout(tcp_io_copy_timeout, tokio::io::copy(&mut ri, &mut wo));
let copy_result = time::timeout( let copy_result = time::timeout(
tcp_io_copy_timeout, tcp_io_copy_timeout,
@@ -678,7 +678,7 @@ async fn transfer<I, O>(inbound: I, outbound: O) -> Result<()>
Ok(r) => r, Ok(r) => r,
} }
}; };
let server_to_client = async { let server_to_client = async move {
// let copy_result = time::timeout(tcp_io_copy_timeout, tokio::io::copy(&mut ro, &mut wi)); // let copy_result = time::timeout(tcp_io_copy_timeout, tokio::io::copy(&mut ro, &mut wi));
let copy_result = time::timeout( let copy_result = time::timeout(
tcp_io_copy_timeout, tcp_io_copy_timeout,