YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-04-02 02:35:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

aquatic_ws: network: handle network errors better

Browse source
This commit is contained in:
Joakim Frostegård 2020-05-11 14:36:47 +02:00
parent 656b0da3c6
commit 6136184890
1 changed files with 22 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

31
aquatic_ws/src/lib/network.rs
View file

@ -353,12 +353,20 @@ pub fn read_and_forward_in_messages(
remove_connection_if_exists(poll, connections, poll_token); remove_connection_if_exists(poll, connections, poll_token);
eprint!("{}", err); eprint!("{}", err);
break
}, },
Err(tungstenite::Error::ConnectionClosed) => { Err(tungstenite::Error::ConnectionClosed) => {
remove_connection_if_exists(poll, connections, poll_token); remove_connection_if_exists(poll, connections, poll_token);
break;
}, },
Err(err) => { Err(err) => {
eprint!("{}", err); dbg!(err);
remove_connection_if_exists(poll, connections, poll_token);
break;
} }
} }
} }
@ -393,18 +401,23 @@ pub fn send_out_messages(
continue; continue;
} }
eprint!("{}", err); dbg!(err);
remove_connection_if_exists(
poll,
connections,
meta.socket_worker_poll_token
);
}, },
Err(tungstenite::Error::ConnectionClosed) => { Err(tungstenite::Error::ConnectionClosed) => {
// FIXME: necessary? remove_connection_if_exists(
poll.registry() poll,
.deregister(connection.ws.get_mut()) connections,
.unwrap(); meta.socket_worker_poll_token
);
connections.remove(&meta.socket_worker_poll_token);
}, },
Err(err) => { Err(err) => {
eprint!("{}", err); dbg!(err);
}, },
} }
} }