apps/engine
1
0
Fork 0
mirror of https://github.com/Monibuca/engine.git synced 2025-10-17 06:00:48 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

对于avcc的时间戳如果为0则写1，防止后面误判成非rtmp体系

Browse Source
This commit is contained in:
dexter
2023-03-14 09:35:36 +08:00
parent 6e874008e4
commit 7e42a85ebf
2 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
common/frame.go
View File

@@ -70,6 +70,9 @@ type AVFrame struct {
} }
func (av *AVFrame) WriteAVCC(ts uint32, frame *util.BLL) { func (av *AVFrame) WriteAVCC(ts uint32, frame *util.BLL) {
if ts == 0 {
ts = 1
}
av.AbsTime = ts av.AbsTime = ts
av.BytesIn += frame.ByteLength av.BytesIn += frame.ByteLength
for { for {

1
subscriber.go
View File

@@ -238,6 +238,7 @@ func (s *Subscriber) PlayBlock(subType byte) {
case SUBTYPE_FLV: case SUBTYPE_FLV:
flvHeadCache := make([]byte, 15) //内存复用 flvHeadCache := make([]byte, 15) //内存复用
sendFlvFrame := func(t byte, ts uint32, avcc ...[]byte) { sendFlvFrame := func(t byte, ts uint32, avcc ...[]byte) {
// fmt.Println(ts)
flvHeadCache[0] = t flvHeadCache[0] = t
result := append(FLVFrame{flvHeadCache[:11]}, avcc...) result := append(FLVFrame{flvHeadCache[:11]}, avcc...)
dataSize := uint32(util.SizeOfBuffers(avcc)) dataSize := uint32(util.SizeOfBuffers(avcc))