Error on listener Start failure
All checks were successful
continuous-integration/drone/push Build is passing
All checks were successful
continuous-integration/drone/push Build is passing
This commit is contained in:
parent
dfc2be9bf2
commit
f8eb6de4c1
|
@ -272,8 +272,11 @@ func (m *Mount) handlePacket(packet packetizer.Packet) {
|
||||||
var err error
|
var err error
|
||||||
for _, l := range m.listeners {
|
for _, l := range m.listeners {
|
||||||
if !l.HasStarted() {
|
if !l.HasStarted() {
|
||||||
//TODO: handle error too?
|
if err = l.Start(m.keepBuffer); err != nil {
|
||||||
l.Start(m.keepBuffer)
|
log.Printf("failed to write data to %s client: %s\n", l.Identifier(), err)
|
||||||
|
toRemove = append(toRemove, l.Identifier())
|
||||||
|
continue
|
||||||
|
}
|
||||||
}
|
}
|
||||||
if err = l.Write(packet); err != nil {
|
if err = l.Write(packet); err != nil {
|
||||||
log.Printf("failed to write data to %s client: %s\n", l.Identifier(), err)
|
log.Printf("failed to write data to %s client: %s\n", l.Identifier(), err)
|
||||||
|
|
Loading…
Reference in a new issue