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

Add quque clean

Browse Source
This commit is contained in:
Lidashuang 2024-03-23 18:01:56 +08:00
parent e73f79a05c
commit e0c5ed1f65
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
format/rtspv2/client.go
View File

@ -119,8 +119,8 @@ func Dial(options RTSPClientOptions) (*RTSPClient, error) {
client := &RTSPClient{ client := &RTSPClient{
headers: make(map[string]string), headers: make(map[string]string),
Signals: make(chan int, 100), Signals: make(chan int, 100),
OutgoingProxyQueue: make(chan *[]byte, 300), OutgoingProxyQueue: make(chan *[]byte, 3000),
OutgoingPacketQueue: make(chan *av.Packet, 300), OutgoingPacketQueue: make(chan *av.Packet, 3000),
BufferRtpPacket: bytes.NewBuffer([]byte{}), BufferRtpPacket: bytes.NewBuffer([]byte{}),
videoID: -1, videoID: -1,
audioID: -2, audioID: -2,
@ -331,7 +331,7 @@ func (client *RTSPClient) startStream() {
} }
for _, i2 := range pkt { for _, i2 := range pkt {
if len(client.OutgoingPacketQueue) > 200 { if len(client.OutgoingPacketQueue) > 2000 {
client.Println("RTSP Client OutgoingPacket Chanel Full") client.Println("RTSP Client OutgoingPacket Chanel Full")
return return
} }