Stop handleDisconnect from double firing

5 years ago · 723a671f1c
1 changed files with 4 additions and 0 deletions
--- a/core/rtmp/rtmp.go
+++ b/core/rtmp/rtmp.go
@ -123,6 +123,10 @@ func HandleConn(c *rtmp.Conn, nc net.Conn) {
				@@ -123,6 +123,10 @@ func HandleConn(c *rtmp.Conn, nc net.Conn) {
 }

 func handleDisconnect(conn net.Conn) {
+	if !_hasInboundRTMPConnection {
+		return
+	}
+
 	log.Infoln("RTMP disconnected.")
 	conn.Close()
 	_pipe.Close()