syndicate-lang
/
syndicate-rkt
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Clean up relay logging

This commit is contained in:
Tony Garnock-Jones 2021-06-10 16:46:28 +02:00
parent b409063ff2
commit 0ba6bac01b
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
syndicate/relay.rkt
View File

@ -16,6 +16,8 @@
(require "schemas/gen/protocol.rkt") (require "schemas/gen/protocol.rkt")
(require (prefix-in sturdy: "schemas/gen/sturdy.rkt")) (require (prefix-in sturdy: "schemas/gen/sturdy.rkt"))
(define-logger syndicate/relay)
;;--------------------------------------------------------------------------- ;;---------------------------------------------------------------------------
(struct inbound (local-handle imported)) (struct inbound (local-handle imported))
@ -146,8 +148,7 @@
(match (parse-Turn packet) (match (parse-Turn packet)
[(? eof-object?) (error 'handle-packet "Invalid IO.Turn")] [(? eof-object?) (error 'handle-packet "Invalid IO.Turn")]
[(Turn wire-turn) [(Turn wire-turn)
(log-info "IN (raw): ~v" packet) (log-syndicate/relay-debug "--> ~a" (preserve->string packet))
(log-info "IN (parsed): ~v" (Turn wire-turn))
(for [(ev (in-list wire-turn))] (for [(ev (in-list wire-turn))]
(match-define (TurnEvent (Oid oid) event) ev) (match-define (TurnEvent (Oid oid) event) ev)
(define r (lookup-local tr oid)) (define r (lookup-local tr oid))
@ -189,8 +190,8 @@
(lambda () (lambda ()
(define pending (Turn (reverse (tunnel-relay-pending-turn-rev tr)))) (define pending (Turn (reverse (tunnel-relay-pending-turn-rev tr))))
(set-tunnel-relay-pending-turn-rev! tr '()) (set-tunnel-relay-pending-turn-rev! tr '())
(log-info "OUT (parsed): ~v" pending) (log-syndicate/relay-debug "<-- ~a"
(log-info "OUT (raw): ~v" (->preserve pending)) (preserve->string (->preserve pending)))
(parse-Turn! (->preserve pending)) (parse-Turn! (->preserve pending))
((tunnel-relay-packet-writer tr) ((tunnel-relay-packet-writer tr)
(preserve->bytes (->preserve pending) (preserve->bytes (->preserve pending)