MeexReay/flowgate
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aaaa

Browse Source
This commit is contained in:
MeexReay 2025-04-13 11:46:00 +03:00
parent 143c701620
commit 0f7b4e82ed
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/server.rs
View File

@ -111,11 +111,10 @@ impl FlowgateServer {
threadpool.execute(move || {
let Ok(connection) = ServerConnection::new(config) else { return };
debug!("{} open connection", addr);
let mut stream = StreamOwned::new(connection, stream);
while stream.conn.is_handshaking() {
let Ok(_) = stream.conn.complete_io(&mut stream.sock) else { return };
}
let Ok(_) = stream.conn.complete_io(&mut stream.sock) else { debug!("{} close connection", addr); return };
local_self.accept_stream(
&mut stream,