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

aquatic_ws: improve channel sending error handling

Browse source
This commit is contained in:
Joakim Frostegård 2021-11-02 12:06:53 +01:00
parent 6140596d7e
commit 98237c928f
2 changed files with 12 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

9
aquatic_ws/src/lib/handlers.rs
View file

@ -105,11 +105,10 @@ async fn handle_request_stream<S>(
}; };
for (meta, out_message) in out_messages.drain(..) { for (meta, out_message) in out_messages.drain(..) {
if let Err(err) = out_message_senders
out_message_senders.send_to(meta.out_message_consumer_id.0, (meta, out_message)).await .send_to(meta.out_message_consumer_id.0, (meta, out_message))
{ .await
::log::error!("failed sending out_message to socket worker: {:?}", err) .expect("failed sending out_message to socket worker");
}
} }
yield_if_needed().await; yield_if_needed().await;

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

@ -159,11 +159,14 @@ async fn receive_out_messages(
.borrow() .borrow()
.get(channel_out_message.0.connection_id.0) .get(channel_out_message.0.connection_id.0)
{ {
if let Err(err) = reference.out_message_sender.try_send(channel_out_message) { match reference.out_message_sender.try_send(channel_out_message) {
::log::error!( Ok(()) | Err(GlommioError::Closed(_)) => {},
"Couldn't send out_message from shared channel to local receiver: {:?}", Err(err) => {
err ::log::error!(
); "Couldn't send out_message from shared channel to local receiver: {:?}",
err
);
}
} }
} }
} }