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))))