We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 874ca28 commit 2e4f3edCopy full SHA for 2e4f3ed
io/zenoh-transport/src/common/pipeline.rs
@@ -822,7 +822,7 @@ impl TransmissionPipelineProducer {
822
// Lock the channel. We are the only one that will be writing on it.
823
let mut queue = zlock!(self.stage_in[idx]);
824
// Check again for congestion in case it happens when blocking on the mutex.
825
- if self.status.is_congested(priority) {
+ if msg.is_droppable() && self.status.is_congested(priority) {
826
return Ok(false);
827
}
828
let mut sent = queue.push_network_message(&msg, priority, &mut deadline)?;
0 commit comments