Skip to content

Commit 2e4f3ed

Browse files
Don't return in case of congestion if message is not droppable (#1855)
1 parent 874ca28 commit 2e4f3ed

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

io/zenoh-transport/src/common/pipeline.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -822,7 +822,7 @@ impl TransmissionPipelineProducer {
822822
// Lock the channel. We are the only one that will be writing on it.
823823
let mut queue = zlock!(self.stage_in[idx]);
824824
// Check again for congestion in case it happens when blocking on the mutex.
825-
if self.status.is_congested(priority) {
825+
if msg.is_droppable() && self.status.is_congested(priority) {
826826
return Ok(false);
827827
}
828828
let mut sent = queue.push_network_message(&msg, priority, &mut deadline)?;

0 commit comments

Comments
 (0)