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

aquatic_ws: update comments

Browse source
This commit is contained in:
Joakim Frostegård 2020-05-11 16:27:42 +02:00
parent f1a20b0c8c
commit f3f2023306
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -165,7 +165,9 @@ pub fn run_socket_worker(
}
/// FIXME: close channel if not closed?
/// FIXME: close ws if not closed? Would be good in some cases, like when
/// connection removed because token has wrapped back, and generally when the
/// reason for removal is not that ws is already closed.
fn remove_connection_if_exists(
poll: &mut Poll,
connections: &mut ConnectionMap,
@ -392,12 +394,12 @@ pub fn run_handshake_and_read_messages(
}
/// Read messages from channel, send to peers
pub fn send_out_messages(
out_message_receiver: ::flume::Drain<(ConnectionMeta, OutMessage)>,
poll: &mut Poll,
connections: &mut ConnectionMap,
){
// Read messages from channel, send to peers
for (meta, out_message) in out_message_receiver {
let opt_connection = connections
.get_mut(&meta.poll_token)