diff options
author | Bryan Newbold <bnewbold@robocracy.org> | 2018-07-31 22:45:14 -0700 |
---|---|---|
committer | Bryan Newbold <bnewbold@robocracy.org> | 2018-07-31 22:46:27 -0700 |
commit | 7662f08f2ec0f0179d42a8f79bc5eeed70fd2dd8 (patch) | |
tree | eec47c826555a822d67afc90be9c8393d0162917 /src/peer.rs | |
parent | 7164f10355fcdc45d3be58bfcee2939937e01623 (diff) | |
download | geniza-old-wip.tar.gz geniza-old-wip.zip |
commit old WIPold-wip
Diffstat (limited to 'src/peer.rs')
-rw-r--r-- | src/peer.rs | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/peer.rs b/src/peer.rs index a020a1a..0ec8f96 100644 --- a/src/peer.rs +++ b/src/peer.rs @@ -28,6 +28,7 @@ pub struct PeerMsg { /// received messages into a channel back to the worker thread. fn receiver_loop(mut dc: DatConnection, peer_rx: chan::Sender<Result<(DatNetMessage, u8)>>) { loop { + println!("receiver_loop tick"); match dc.recv_msg() { Ok((msg, feed_index)) => { peer_rx.send(Ok((msg, feed_index))); @@ -57,6 +58,7 @@ fn worker_thread(mut dc: DatConnection, handle: u64, outbound_chan: chan::Receiv }); loop { + println!("worker_loop tick"); chan_select!{ outbound_chan.recv() -> val => { if let Some((msg, feed_index)) = val { |