Method WriteRTPFrame

track/av1.go:51–86

(rtpItem *LIRTP)

}

func (vt *AV1) WriteRTPFrame(rtpItem *LIRTP) {
	defer func() {
		err := recover()
		if err != nil {
			vt.Error("WriteRTPFrame panic", zap.Any("err", err))
			vt.Publisher.Stop(zap.Any("err", err))
		}
	}()
	if vt.lastSeq != vt.lastSeq2+1 && vt.lastSeq2 != 0 {
		vt.lostFlag = true
		vt.Warn("lost rtp packet", zap.Uint16("lastSeq", vt.lastSeq), zap.Uint16("lastSeq2", vt.lastSeq2))
	}
	frame := &rtpItem.Value
	rv := vt.Value
	rv.RTP.Push(rtpItem)
	obus, err := vt.decoder.Decode(frame.Packet)
	for _, obu := range obus {
		var obuHeader av1.OBUHeader
		obuHeader.Unmarshal(obu)
		switch obuHeader.Type {
		case av1.OBUTypeSequenceHeader:
			rtmpHead := []byte{0b1001_0000 | byte(codec.PacketTypeMPEG2TSSequenceStart), 0, 0, 0, 0}
			util.BigEndian.PutUint32(rtmpHead[1:], codec.FourCC_AV1_32)
			// TODO: 生成 head
			rtmpHead = append(rtmpHead, obu...)
			vt.Video.WriteSequenceHead(rtmpHead)
			vt.ParamaterSets[0] = obu
		default:
			rv.AUList.Push(vt.BytesPool.GetShell(obu))
		}
	}
	if err == nil {
		vt.generateTimestamp(frame.Timestamp)
		vt.Flush()
	}
}

func (vt *AV1) writeAVCCFrame(ts uint32, r *util.BLLReader, frame *util.BLL) (err error) {
	vt.Value.PTS = time.Duration(ts) * 90