kunmeng/vdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: Added RTSP status connection flush

Browse Source
This commit is contained in:
Dave Taddei 2022-09-19 15:11:11 +01:00
parent 6ac73320a8
commit b844ff4205
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
format/rtspv2/client.go
View File

@ -281,9 +281,7 @@ func (client *RTSPClient) startStream() {
return return
} }
if metaData.SSRC != 0 { client.sendRR(metaData)
client.sendRR(metaData)
}
timer = time.Now() timer = time.Now()
} }
@ -392,6 +390,7 @@ func (client *RTSPClient) sendRR(metaData RTPMetadata) (err error) {
client.Println("Sending ReceiverReport", metaData) client.Println("Sending ReceiverReport", metaData)
err = client.conn.SetDeadline(time.Now().Add(client.options.ReadWriteTimeout)) err = client.conn.SetDeadline(time.Now().Add(client.options.ReadWriteTimeout))
if err != nil { if err != nil {
client.Println("Error setting connection timeout: ", err)
return return
} }
client.seq++ client.seq++
@ -414,12 +413,20 @@ func (client *RTSPClient) sendRR(metaData RTPMetadata) (err error) {
data, err := rr.Marshal() data, err := rr.Marshal()
if err != nil { if err != nil {
client.Println("Error marshalling receiver report: ", err)
return return
} }
nb, err := client.connRW.Write(data) nb, err := client.connRW.Write(data)
if err != nil || nb == 0 { if err != nil || nb == 0 {
client.Println("Error sending receiver report: ", err)
return
}
err = client.connRW.Flush()
if err != nil {
client.Println("Error flushing receiver report: ", err)
return return
} }