More detailed debug log
This commit is contained in:
@@ -194,6 +194,8 @@ func (e *Handler) handleControl(d byte, l log.Logger) error {
|
|||||||
|
|
||||||
switch buf[0] {
|
switch buf[0] {
|
||||||
case HeaderControlEcho:
|
case HeaderControlEcho:
|
||||||
|
l.Debug("Echo %d bytes", d)
|
||||||
|
|
||||||
hd := HeaderControl
|
hd := HeaderControl
|
||||||
hd.Set(d)
|
hd.Set(d)
|
||||||
|
|
||||||
@@ -217,12 +219,20 @@ func (e *Handler) handleControl(d byte, l log.Logger) error {
|
|||||||
if !e.senderPaused {
|
if !e.senderPaused {
|
||||||
e.sender.pause()
|
e.sender.pause()
|
||||||
e.senderPaused = true
|
e.senderPaused = true
|
||||||
|
|
||||||
|
l.Debug("Pause Stream")
|
||||||
|
} else {
|
||||||
|
l.Debug("Repeated Pause Stream command, ignore")
|
||||||
}
|
}
|
||||||
|
|
||||||
case HeaderControlResumeStream:
|
case HeaderControlResumeStream:
|
||||||
if e.senderPaused {
|
if e.senderPaused {
|
||||||
e.sender.resume()
|
e.sender.resume()
|
||||||
e.senderPaused = false
|
e.senderPaused = false
|
||||||
|
|
||||||
|
l.Debug("Resume Stream")
|
||||||
|
} else {
|
||||||
|
l.Debug("Repeated Resume Stream command, ignore")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -390,7 +390,13 @@ func (c *stream) reinit(
|
|||||||
c.f = ccc
|
c.f = ccc
|
||||||
c.closed = false
|
c.closed = false
|
||||||
|
|
||||||
signaller.Signal(bootErr.code, true)
|
sErr := signaller.Signal(bootErr.code, true)
|
||||||
|
|
||||||
|
if sErr != nil {
|
||||||
|
return sErr
|
||||||
|
}
|
||||||
|
|
||||||
|
l.Debug("Started")
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user