From ec5099c1113e2a5abd27cb310334fb70f6691996 Mon Sep 17 00:00:00 2001 From: NI Date: Tue, 24 Sep 2019 22:47:32 +0800 Subject: [PATCH] More detailed debug log --- application/command/handler.go | 10 ++++++++++ application/command/streams.go | 8 +++++++- 2 files changed, 17 insertions(+), 1 deletion(-) diff --git a/application/command/handler.go b/application/command/handler.go index 403d25c..e861d85 100644 --- a/application/command/handler.go +++ b/application/command/handler.go @@ -194,6 +194,8 @@ func (e *Handler) handleControl(d byte, l log.Logger) error { switch buf[0] { case HeaderControlEcho: + l.Debug("Echo %d bytes", d) + hd := HeaderControl hd.Set(d) @@ -217,12 +219,20 @@ func (e *Handler) handleControl(d byte, l log.Logger) error { if !e.senderPaused { e.sender.pause() e.senderPaused = true + + l.Debug("Pause Stream") + } else { + l.Debug("Repeated Pause Stream command, ignore") } case HeaderControlResumeStream: if e.senderPaused { e.sender.resume() e.senderPaused = false + + l.Debug("Resume Stream") + } else { + l.Debug("Repeated Resume Stream command, ignore") } } diff --git a/application/command/streams.go b/application/command/streams.go index 31ca9ff..455700b 100644 --- a/application/command/streams.go +++ b/application/command/streams.go @@ -390,7 +390,13 @@ func (c *stream) reinit( c.f = ccc c.closed = false - signaller.Signal(bootErr.code, true) + sErr := signaller.Signal(bootErr.code, true) + + if sErr != nil { + return sErr + } + + l.Debug("Started") return nil }