diff --git a/format/rtspv2/client.go b/format/rtspv2/client.go index 2bd59c7..b622ad9 100644 --- a/format/rtspv2/client.go +++ b/format/rtspv2/client.go @@ -510,13 +510,17 @@ func (client *RTSPClient) request(method string, customHeaders map[string]string } func (client *RTSPClient) Pause() error { + if err := client.request(PAUSE, nil, client.pURL.String(), false, true); err != nil { + return err + } client.status = PAUSE - return client.request(PAUSE, nil, client.pURL.String(), false, true) } 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 - return client.request(PLAY, customHeaders, client.pURL.String(), false, true) } func (client *RTSPClient) Close() { diff --git a/format/rtspv2/demuxer.go b/format/rtspv2/demuxer.go index 01433dd..1fb28ce 100644 --- a/format/rtspv2/demuxer.go +++ b/format/rtspv2/demuxer.go @@ -78,9 +78,9 @@ func (client *RTSPClient) handleVideo(content []byte) ([]*av.Packet, bool) { client.PreVideoTS = 0 } } - if client.PreSequenceNumber != 0 && client.sequenceNumber-client.PreSequenceNumber != 1 { - client.Println("drop packet", client.sequenceNumber-1) - } + // if client.PreSequenceNumber != 0 && client.sequenceNumber-client.PreSequenceNumber != 1 { + // client.Println("drop packet", client.sequenceNumber-1) + // } client.PreSequenceNumber = client.sequenceNumber if client.BufferRtpPacket.Len() > 4048576 { client.Println("Big Buffer Flush")