syndicate-lang
/
syndicate-rs
1
0
Fork 0
Code Issues 3 Pull Requests Actions Projects Releases Wiki Activity

Tidy up output

This commit is contained in:
Tony Garnock-Jones 2019-10-19 23:26:15 +01:00
parent 05703d9a35
commit 7da6115f59
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/peer.rs
View File

@ -36,7 +36,7 @@ impl Peer {
} }
pub async fn run(&mut self, spaces: Arc<Mutex<Map<V, ()>>>) -> Result<(), std::io::Error> { pub async fn run(&mut self, spaces: Arc<Mutex<Map<V, ()>>>) -> Result<(), std::io::Error> {
println!("{:?}: got {:?}", self.id, &self.frames.get_ref()); println!("{:?}: {:?}", self.id, &self.frames.get_ref());
let firstpacket = self.frames.next().await; let firstpacket = self.frames.next().await;
let dsname = if let Some(Ok(packets::In::Connect(dsname))) = firstpacket { let dsname = if let Some(Ok(packets::In::Connect(dsname))) = firstpacket {
@ -95,7 +95,7 @@ impl Peer {
} }
Err(packets::DecodeError::Parse(e, v)) => { Err(packets::DecodeError::Parse(e, v)) => {
to_send.push(err(&format!( to_send.push(err(&format!(
"Packet deserialization error ({}) decoding {:?} ", e, v))); "Packet deserialization error ({}) decoding {:?}", e, v)));
running = false; running = false;
} }
} }
@ -114,9 +114,9 @@ impl Peer {
} }
for v in to_send { for v in to_send {
if let packets::Out::Err(ref msg) = v { if let packets::Out::Err(ref msg) = v {
println!("{:?}: Connection crashed with error {:?}", self.id, msg); println!("{:?}: connection crashed: {}", self.id, msg);
} else { } else {
println!("{:?}: Output {:?}", self.id, &v); println!("{:?}: output {:?}", self.id, &v);
} }
self.frames.send(v).await?; self.frames.send(v).await?;
} }