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

add client status

Browse Source
This commit is contained in:
Lidashuang 2024-03-14 19:23:10 +08:00
parent 42c53daeab
commit 064ca7bcf9
2 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
format/rtspv2/client.go
View File

@ -510,13 +510,17 @@ func (client *RTSPClient) request(method string, customHeaders map[string]string
} }
func (client *RTSPClient) Pause() error { func (client *RTSPClient) Pause() error {
if err := client.request(PAUSE, nil, client.pURL.String(), false, true); err != nil {
return err
}
client.status = PAUSE client.status = PAUSE
return client.request(PAUSE, nil, client.pURL.String(), false, true)
} }
func (client *RTSPClient) Play(customHeaders map[string]string) error { func (client *RTSPClient) Play(customHeaders map[string]string) error {
if err := client.request(PLAY, customHeaders, client.pURL.String(), false, true); err != nil {
return err
}
client.status = PLAY client.status = PLAY
return client.request(PLAY, customHeaders, client.pURL.String(), false, true)
} }
func (client *RTSPClient) Close() { func (client *RTSPClient) Close() {

6
format/rtspv2/demuxer.go
View File

@ -78,9 +78,9 @@ func (client *RTSPClient) handleVideo(content []byte) ([]*av.Packet, bool) {
client.PreVideoTS = 0 client.PreVideoTS = 0
} }
} }
if client.PreSequenceNumber != 0 && client.sequenceNumber-client.PreSequenceNumber != 1 { // if client.PreSequenceNumber != 0 && client.sequenceNumber-client.PreSequenceNumber != 1 {
client.Println("drop packet", client.sequenceNumber-1) // client.Println("drop packet", client.sequenceNumber-1)
} // }
client.PreSequenceNumber = client.sequenceNumber client.PreSequenceNumber = client.sequenceNumber
if client.BufferRtpPacket.Len() > 4048576 { if client.BufferRtpPacket.Len() > 4048576 {
client.Println("Big Buffer Flush") client.Println("Big Buffer Flush")