Function WritePMTPacket

codec/mpegts/mpegts_pmt.go:342–368

func WritePMTPacket(w io.Writer, tsHeader []byte, pmt MpegTsPMT) (err error) { if pmt.TableID != TABLE_TSPMS { err = errors.New("PMT table ID error") return } // 将所有要写的数据(PMT),全部放入到buffer中去. // buffer 里面已经写好了整个PMT表(PointerField+PSI+PMT+CRC) bw := &bytes.Buffer{} if err = WritePMT(bw, pmt)

(w io.Writer, videoCodec codec.VideoCodecID, audioCodec codec.AudioCodecID)

// }

func WritePMTPacket(w io.Writer, videoCodec codec.VideoCodecID, audioCodec codec.AudioCodecID) {
	w.Write(TSHeader)
	crc := make([]byte, 4)
	paddingSize := TS_PACKET_SIZE - len(crc) - len(PSI) - len(PMT) - len(TSHeader) - 10
	pmt := net.Buffers{PSI, PMT}
	switch videoCodec {
	case codec.CodecID_H264:
		pmt = append(pmt, h264)
	case codec.CodecID_H265:
		pmt = append(pmt, h265)
	default:
		paddingSize += 5
	}
	switch audioCodec {
	case codec.CodecID_AAC:
		pmt = append(pmt, aac)
	case codec.CodecID_PCMA:
		pmt = append(pmt, pcma)
	case codec.CodecID_PCMU:
		pmt = append(pmt, pcmu)
	default:
		paddingSize += 5
	}
	util.PutBE(crc, GetCRC32_2(pmt))
	pmt = append(pmt, crc, Stuffing[:paddingSize])
	pmt.WriteTo(w)
}