diff --git a/src/rtsp2rtmp/flvadmin/rtmpflvwriter/rtmpflvwriter.go b/src/rtsp2rtmp/flvadmin/rtmpflvwriter/rtmpflvwriter.go index cc79244..ecbab08 100644 --- a/src/rtsp2rtmp/flvadmin/rtmpflvwriter/rtmpflvwriter.go +++ b/src/rtsp2rtmp/flvadmin/rtmpflvwriter/rtmpflvwriter.go @@ -268,7 +268,11 @@ func (rfw *RtmpFlvWriter) writerPacket(pkt av.Packet, templateTime *time.Time) e return err } logs.Info("KeyFrame WriteHeader to rtmp server success : %s", rfw.code) + // setDeadline + rfw.conn.NetConn().SetDeadline(time.Now().Add(10 * time.Second)) err = rfw.conn.WritePacket(pkt) + // clear Deadline + rfw.conn.NetConn().SetDeadline(time.Time{}) if err != nil { logs.Error("writer packet to rtmp server error : %v", err) return err