apps/lkm
1
0
Fork 0
mirror of https://github.com/lkmio/lkm.git synced 2025-10-05 15:16:49 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

修复收流数据被覆盖问题

Browse Source
This commit is contained in:
yangjiechina
2024-07-05 21:42:51 +08:00
parent 360610916f
commit 217605072e
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
stream/source.go
View File

@@ -193,8 +193,8 @@ func (s *PublishSource) Init(inputCB func(data []byte) error, closeCB func(), re
s.SetState(SessionStateHandshakeDone) s.SetState(SessionStateHandshakeDone)
//初始化事件接收缓冲区 //初始化事件接收缓冲区
//收流和网络断开的chan都阻塞执行 //收流和网络断开的chan都阻塞执行
//-1是为了保证从管道取到流, 到解析流是安全的, 不会被覆盖 //-2是为了保证从管道取到流, 到处理完流.整个过程安全的, 不会被覆盖
s.inputDataEvent = make(chan []byte, receiveQueueSize-1) s.inputDataEvent = make(chan []byte, receiveQueueSize-2)
s.closedEvent = make(chan byte) s.closedEvent = make(chan byte)
s.playingEventQueue = make(chan Sink, 128) s.playingEventQueue = make(chan Sink, 128)
s.playingDoneEventQueue = make(chan Sink, 128) s.playingDoneEventQueue = make(chan Sink, 128)