Sulkta-OSS/pallas
3
0
Fork 0
Code Issues 1 Pull requests 4 Projects Releases Packages Wiki Activity Actions

fix(upstream): Use sync read for chunk dequeue (#239)

Browse source
This commit is contained in:
Santiago Carmuega 2023-03-24 02:58:29 +01:00 • committed by GitHub
parent 70355a687d
commit 66a095df4a
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
pallas-multiplexer/src/mux.rs
View file

@ -44,7 +44,7 @@ where
} }
pub fn tick(&mut self) -> TickOutcome { 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)) => { Ok((id, payload)) => {
let segment = Segment::new(self.clock, id, payload); let segment = Segment::new(self.clock, id, payload);

2
pallas-upstream/src/framework.rs
View file

@ -51,7 +51,7 @@ impl multiplexer::agents::Channel for ProtocolChannel {
} }
fn dequeue_chunk(&mut self) -> Result<multiplexer::Payload, multiplexer::agents::ChannelError> { 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), Ok(msg) => Ok(msg.payload),
Err(error) => { Err(error) => {
error!(?error, "dequeue chunk failed"); error!(?error, "dequeue chunk failed");