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 }