fix(upstream): Use sync read for chunk dequeue

txpipe · Mar 24, 2023 · 0b25c3c · 0b25c3c
1 parent 27d29ac
commit 0b25c3c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pallas-multiplexer/src/mux.rs b/pallas-multiplexer/src/mux.rs
@@ -44,7 +44,7 @@ where
     }
 
     pub fn tick(&mut self) -> TickOutcome {
-        match self.ingress.recv_timeout(Duration::from_millis(500)) {
+        match self.ingress.recv_timeout(Duration::from_millis(1)) {
             Ok((id, payload)) => {
                 let segment = Segment::new(self.clock, id, payload);
 

diff --git a/pallas-upstream/src/framework.rs b/pallas-upstream/src/framework.rs
@@ -51,7 +51,7 @@ impl multiplexer::agents::Channel for ProtocolChannel {
     }
 
     fn dequeue_chunk(&mut self) -> Result<multiplexer::Payload, multiplexer::agents::ChannelError> {
-        match self.2.recv_or_idle() {
+        match self.2.recv() {
             Ok(msg) => Ok(msg.payload),
             Err(error) => {
                 error!(?error, "dequeue chunk failed");