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/synchronizer.rs | |
parent | 7164f10355fcdc45d3be58bfcee2939937e01623 (diff) | |
download | geniza-7662f08f2ec0f0179d42a8f79bc5eeed70fd2dd8.tar.gz geniza-7662f08f2ec0f0179d42a8f79bc5eeed70fd2dd8.zip |
commit old WIPold-wip
Diffstat (limited to 'src/synchronizer.rs')
-rw-r--r-- | src/synchronizer.rs | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/synchronizer.rs b/src/synchronizer.rs index cfc4cd3..a4c156b 100644 --- a/src/synchronizer.rs +++ b/src/synchronizer.rs @@ -125,6 +125,7 @@ impl Synchronizer { let unified_peers_rx = self.unified_peers_rx.clone(); loop { + print!("."); chan_select! { unified_peers_rx.recv() -> val => { if let Some(Ok(pm)) = val { @@ -141,7 +142,9 @@ impl Synchronizer { // mutable ref to PeerThread for this message let pt = self.peers.get_mut(&pm.peer_handle).unwrap(); - // NB: this is the simplistic model of registers (only works up to 2x per peer?) + // XXX: debug, not warn + warn!("Got a message (feed={}): {:?}", pm.feed_index, pm.msg); + if pm.feed_index as usize >= self.registers.len() { // Ignore feed channels we haven't registered yet return Ok(()); |