don't upload playlist if closed (#620)

livekit · Feb 28, 2024 · 1c3af41 · 1c3af41
1 parent 8ea6b05
commit 1c3af41
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/pipeline/sink/segments.go b/pkg/pipeline/sink/segments.go
@@ -199,6 +199,9 @@ func (s *SegmentSink) handlePlaylistUpdates(update SegmentUpdate) error {
 	s.throttle(func() {
 		s.playlistLock.Lock()
 		defer s.playlistLock.Unlock()
+		if s.done.IsBroken() {
+			return
+		}
 
 		if err := s.uploadPlaylist(); err != nil {
 			s.callbacks.OnError(err)