aboutsummaryrefslogtreecommitdiffstats
path: root/src/synchronizer.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/synchronizer.rs')
-rw-r--r--src/synchronizer.rs5
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(());