Sulkta-Coop/pallas
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

fix(machines): Don't warn on expected end-of-input errors (#15)

Browse source
This commit is contained in:
Santiago Carmuega 2022-01-02 10:29:46 -03:00 • committed by GitHub
parent 38ae2d3aee
commit c566769c51
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

7
pallas-machines/src/payloads.rs
View file

@ -1,6 +1,6 @@
use super::*;
use log::{debug, warn};
use log::debug;
use minicbor::{Decoder, Encoder};
use pallas_multiplexer::Payload;
use std::{
@ -142,9 +142,8 @@ impl<'a> PayloadDeconstructor<'a> {
debug!("consumed {} from payload buffer", new_pos);
Ok(t)
}
Err(err) => {
//TODO: we need to filter this only for correct errors
warn!("{:?}", err);
Err(_err) => {
//TODO: we need to match EndOfInput kind of errors
debug!("payload incomplete, fetching next segment");
let payload = self.rx.recv()?;

4
pallas-multiplexer/src/lib.rs
View file

@ -8,7 +8,7 @@ use std::{
time::{Duration, Instant},
};
use log::{debug, error, trace, warn};
use log::{debug, error, warn};
pub trait Bearer: Read + Write + Send + Sync + Sized {
fn read_segment(&mut self) -> Result<(u16, u32, Payload), std::io::Error>;
@ -49,7 +49,7 @@ where
}
Err(TryRecvError::Disconnected) => {
//TODO: remove handle from list
trace!("protocol handle {} disconnected", id);
warn!("protocol handle {} disconnected", id);
}
Err(TryRecvError::Empty) => (),
};