From 7662f08f2ec0f0179d42a8f79bc5eeed70fd2dd8 Mon Sep 17 00:00:00 2001
From: Bryan Newbold <bnewbold@robocracy.org>
Date: Tue, 31 Jul 2018 22:45:14 -0700
Subject: commit old WIP

---
 src/synchronizer.rs | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

(limited to 'src/synchronizer.rs')

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(());
-- 
cgit v1.2.3