Disconnect broadcaster in case of a segmentation error.

livepeer · Jun 12, 2018 · 26f26ca · 26f26ca
1 parent 15e5e7a
commit 26f26ca
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/server/mediaserver.go b/server/mediaserver.go
@@ -254,6 +254,9 @@ func gotRTMPStreamHandler(s *LivepeerServer) func(url *url.URL, rtmpStrm stream.
 				if err := s.LivepeerNode.BroadcastFinishMsg(hlsStrmID.String()); err != nil {
 					glog.Errorf("Error broadcaseting finish message: %v", err)
 				}
+				// Stop the incoming RTMP connection.
+				// TODO retry segmentation if err != SegmenterTimeout; may be recoverable
+				rtmpStrm.Close()
 			}
 		}(broadcaster, rtmpStrm)