Method remux

pkg/remux/rtmp2rtsp.go:239–291

(msg base.RtmpMsg)

}

func (r *Rtmp2RtspRemuxer) remux(msg base.RtmpMsg) {
	var packer *rtprtcp.RtpPacker
	var rtppkts []rtprtcp.RtpPacket
	switch msg.Header.MsgTypeId {
	case base.RtmpTypeIdAudio:
		packer = r.getAudioPacker()
		if packer != nil {
			if msg.AudioCodecId() == base.RtmpSoundFormatG711A || msg.AudioCodecId() == base.RtmpSoundFormatG711U || msg.AudioCodecId() == base.RtmpSoundFormatOpus {
				rtppkts = packer.Pack(base.AvPacket{
					Timestamp:   int64(msg.Header.TimestampAbs),
					PayloadType: r.audioPt,
					Payload:     msg.Payload[1:],
				})
			} else {
				rtppkts = packer.Pack(base.AvPacket{
					Timestamp:   int64(msg.Header.TimestampAbs),
					PayloadType: r.audioPt,
					Payload:     msg.Payload[2:],
				})
			}
		}
	case base.RtmpTypeIdVideo:
		packer = r.getVideoPacker()
		if packer != nil {
			var payload []byte
			if msg.VideoCodecId() == base.RtmpCodecIdHevc && msg.IsEnchanedHevcNalu() {
				index := msg.GetEnchanedHevcNaluIndex()
				payload = msg.Payload[index:]
			} else {
				payload = msg.Payload[5:]
			}

			if RtspRemuxerAddSpsPps2KeyFrameFlag {
				if msg.IsAvcKeyNalu() && r.sps != nil && r.pps != nil {
					payload = h2645.JoinNaluAvcc(r.sps, r.pps, msg.Payload[9:])
				}
				if msg.IsHevcKeyNalu() && r.vps != nil && r.sps != nil && r.pps != nil {
					payload = h2645.JoinNaluAvcc(r.vps, r.sps, r.pps, msg.Payload[9:])
				}
			}

			rtppkts = r.getVideoPacker().Pack(base.AvPacket{
				Timestamp:   int64(msg.Header.TimestampAbs),
				PayloadType: r.videoPt,
				Payload:     payload,
			})
		}
	}

	for i := range rtppkts {
		r.onRtpPacket(rtppkts[i])
	}
}

func (r *Rtmp2RtspRemuxer) getAudioPacker() *rtprtcp.RtpPacker {
	if r.audioPacker == nil {