aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorHimbeerserverDE <himbeerserverde@gmail.com>2023-09-03 16:40:04 +0200
committerHimbeerserverDE <himbeerserverde@gmail.com>2023-09-03 16:40:04 +0200
commit4956b3295b87cf617a95abeeab044fde337c28ab (patch)
treecf5409c85dbe925957811654b92ffedb7cbbbad4
parentf7a03b2cfabecd81d2b9fff3aca6244f45aa6241 (diff)
[client & server] Only log finish errors for our own closure attempts
-rw-r--r--src/shared/channel.rs12
1 files changed, 7 insertions, 5 deletions
diff --git a/src/shared/channel.rs b/src/shared/channel.rs
index 1508dab..cad6021 100644
--- a/src/shared/channel.rs
+++ b/src/shared/channel.rs
@@ -2,7 +2,7 @@ use super::QuinnetError;
use bevy::prelude::{error, trace};
use bytes::Bytes;
use futures::{sink::SinkExt, StreamExt};
-use quinn::{RecvStream, SendDatagramError, SendStream, VarInt};
+use quinn::{ConnectionError, RecvStream, SendDatagramError, SendStream, VarInt};
use std::fmt::{Debug, Display};
use tokio::sync::{
broadcast,
@@ -234,10 +234,12 @@ pub(crate) async fn ordered_reliable_channel_task(
);
}
if let Err(err) = frame_sender.into_inner().finish().await {
- error!(
- "Failed to shutdown Ordered Reliable Channel stream gracefully: {}",
- err
- );
+ if let Some(ConnectionError::LocallyClosed) = connection.close_reason() {
+ error!(
+ "Failed to shutdown Ordered Reliable Channel stream gracefully: {}",
+ err
+ );
+ }
}
}