GRIN/nym
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix comments

Browse Source
This commit is contained in:
Tommy Verrall
2025-10-23 19:22:26 +02:00
parent aa0d15ee67
commit 67c32faa11
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/client-core/src/client/real_messages_control/real_traffic_stream.rs
+3 -4
View File
@@ -301,8 +301,7 @@ where
tracing::error!(
"failed to send mixnet packet due to closed channel (outside of shutdown!)"
);
// This prevents an infinite loop where we keep trying to send
// packets through a closed channel
// This prevents a loop where we keep trying to send packets through a closed channel
self.mix_tx_closed = true;
}
// Early return to avoid further processing when channel is closed
@@ -611,7 +610,7 @@ where
next_message = self.next() => if let Some(next_message) = next_message {
self.on_message(next_message).await;
// Check if mix_tx channel was closed during on_message
// and break immediately to prevent infinite loop
// and break immediately to prevent loop
if self.mix_tx_closed {
tracing::error!("OutQueueControl: mix_tx channel closed, stopping traffic stream");
break;
@@ -636,7 +635,7 @@ where
next_message = self.next() => if let Some(next_message) = next_message {
self.on_message(next_message).await;
// Check if mix_tx channel was closed during on_message
// and break immediately to prevent infinite loop
// and break immediately to prevent loop
if self.mix_tx_closed {
tracing::error!("OutQueueControl: mix_tx channel closed, stopping traffic stream");
break;