From f8eb6de4c1059acd20e541d4117e1adcbf65b43f Mon Sep 17 00:00:00 2001 From: WeebDataHoarder <57538841+WeebDataHoarder@users.noreply.github.com> Date: Sun, 2 Oct 2022 15:38:51 +0200 Subject: [PATCH] Error on listener Start failure --- stream/mount.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/stream/mount.go b/stream/mount.go index abd4500..c1f3147 100644 --- a/stream/mount.go +++ b/stream/mount.go @@ -272,8 +272,11 @@ func (m *Mount) handlePacket(packet packetizer.Packet) { var err error for _, l := range m.listeners { if !l.HasStarted() { - //TODO: handle error too? - l.Start(m.keepBuffer) + if err = l.Start(m.keepBuffer); err != nil { + 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 { log.Printf("failed to write data to %s client: %s\n", l.Identifier(), err)