rtmp source: allow outgoing acknowledges

bluenviron · Aug 16, 2022 · 85ce121 · 85ce121
1 parent 7216fc6
commit 85ce121
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/internal/core/rtmp_conn.go b/internal/core/rtmp_conn.go
@@ -527,7 +527,7 @@ func (c *rtmpConn) runPublish(ctx context.Context, u *url.URL) error {
 		c.path.Name(),
 		sourceTrackInfo(tracks))
 
-	// disable write deadline
+	// disable write deadline to allow outgoing acknowledges
 	c.nconn.SetWriteDeadline(time.Time{})
 
 	for {

diff --git a/internal/core/rtmp_source.go b/internal/core/rtmp_source.go
@@ -148,6 +148,9 @@ func (s *rtmpSource) run(ctx context.Context) error {
 				s.parent.sourceStaticImplSetNotReady(pathSourceStaticSetNotReadyReq{})
 			}()
 
+			// disable write deadline to allow outgoing acknowledges
+			nconn.SetWriteDeadline(time.Time{})
+
 			for {
 				nconn.SetReadDeadline(time.Now().Add(time.Duration(s.readTimeout)))
 				msg, err := conn.ReadMessage()