From 8aaf1d1902ded284dd34e0c03c5499882848d162 Mon Sep 17 00:00:00 2001
From: Tony Garnock-Jones <tonygarnockjones@gmail.com>
Date: Mon, 20 May 2019 21:45:40 +0100
Subject: [PATCH] Improve distributed debug output

---
 syndicate/distributed/client.rkt |  6 ++++++
 syndicate/distributed/main.rkt   | 17 +++++++++++++----
 2 files changed, 19 insertions(+), 4 deletions(-)

diff --git a/syndicate/distributed/client.rkt b/syndicate/distributed/client.rkt
index b5ed280..a6ca427 100644
--- a/syndicate/distributed/client.rkt
+++ b/syndicate/distributed/client.rkt
@@ -19,6 +19,12 @@
   (on-stop (log-syndicate/distributed-info "Disconnected from ~v" address))
   (assert (server-connected address))
 
+  (when (log-level? syndicate/distributed-logger 'debug)
+    (set! w (let ((w* w))
+              (lambda (p)
+                (log-syndicate/distributed-debug "C OUT ~v ~v" address p)
+                (w* p)))))
+
   (on-start (w (Connect scope)))
 
   (define next-ep
diff --git a/syndicate/distributed/main.rkt b/syndicate/distributed/main.rkt
index 4a1ba15..3fd48a2 100644
--- a/syndicate/distributed/main.rkt
+++ b/syndicate/distributed/main.rkt
@@ -73,12 +73,21 @@
 (define-logger syndicate/distributed)
 
 (when (log-level? syndicate/distributed-logger 'debug)
+  (spawn #:name 'client-debug
+         (on (asserted (server-connection $addr))
+             (log-syndicate/distributed-debug "C + ~v" addr))
+         (on (retracted (server-connection $addr))
+             (log-syndicate/distributed-debug "C - ~v" addr))
+         (on (message (server-packet $addr $p))
+             (log-syndicate/distributed-debug "C IN  ~v ~v" addr p))
+         ;; C OUT is covered in client.rkt
+         )
   (spawn #:name 'server-debug
          (on (asserted (server-poa $id))
-             (log-syndicate/distributed-debug "+ ~v" id))
+             (log-syndicate/distributed-debug "S + ~v" id))
          (on (retracted (server-poa $id))
-             (log-syndicate/distributed-debug "- ~v" id))
+             (log-syndicate/distributed-debug "S - ~v" id))
          (on (message (message-poa->server $id $p))
-             (log-syndicate/distributed-debug "IN  ~v ~v" id p))
+             (log-syndicate/distributed-debug "S IN  ~v ~v" id p))
          (on (message (message-server->poa $id $p))
-             (log-syndicate/distributed-debug "OUT ~v ~v" id p))))
+             (log-syndicate/distributed-debug "S OUT ~v ~v" id p))))