Function ReadTsHeader

codec/mpegts/mpegts.go:208–378

(r io.Reader)

}

func ReadTsHeader(r io.Reader) (header MpegTsHeader, err error) {
	var h uint32

	// MPEGTS Header 4个字节
	h, err = util.ReadByteToUint32(r, true)
	if err != nil {
		return
	}

	// payloadUnitStartIndicator
	// 为1时,表示在4个字节后,有一个调整字节.包头后需要除去一个字节才是有效数据(payload_unit_start_indicator="1")
	// header.payloadUnitStartIndicator = uint8(h & 0x400000)

	// | 1111 1111 | 0000 0000 | 0000 0000 | 0000 0000 |

	// | 1111 1111 | 0000 0000 | 0000 0000 | 0000 0000 |
	header.SyncByte = byte((h & 0xff000000) >> 24)

	if header.SyncByte != 0x47 {
		err = errors.New("mpegts header sync error!")
		return
	}

	// | 0000 0000 | 1000 0000 | 0000 0000 | 0000 0000 |
	header.TransportErrorIndicator = byte((h & 0x800000) >> 23)

	// | 0000 0000 | 0100 0000 | 0000 0000 | 0000 0000 |
	header.PayloadUnitStartIndicator = byte((h & 0x400000) >> 22)

	// | 0000 0000 | 0010 0000 | 0000 0000 | 0000 0000 |
	header.TransportPriority = byte((h & 0x200000) >> 21)

	// | 0000 0000 | 0001 1111 | 1111 1111 | 0000 0000 |
	header.Pid = uint16((h & 0x1fff00) >> 8)

	// | 0000 0000 | 0000 0000 | 0000 0000 | 1100 0000 |
	header.TransportScramblingControl = byte((h & 0xc0) >> 6)

	// | 0000 0000 | 0000 0000 | 0000 0000 | 0011 0000 |
	// 0x30 , 0x20 -> adaptation_field, 0x10 -> Payload
	header.AdaptionFieldControl = byte((h & 0x30) >> 4)

	// | 0000 0000 | 0000 0000 | 0000 0000 | 0000 1111 |
	header.ContinuityCounter = byte(h & 0xf)

	// | 0010 0000 |
	// adaptionFieldControl
	// 表示TS分组首部后面是否跟随有调整字段和有效负载.
	// 01仅含有效负载(没有adaptation_field)
	// 10仅含调整字段(没有Payload)
	// 11含有调整字段和有效负载(有adaptation_field,adaptation_field之后是Payload).
	// 为00的话解码器不进行处理.空分组没有调整字段
	// 当值为'11时,adaptation_field_length 值必须在0 到182 的区间内.
	// 当值为'10'时,adaptation_field_length 值必须为183.
	// 对于承载PES 包的传输流包,只要存在欠充足的PES 包数据就需要通过填充来完全填满传输流包的有效载荷字节.
	// 填充通过规定自适应字段长度比自适应字段中数据元的长度总和还要长来实现,以致于自适应字段在完全容纳有效的PES 包数据后,有效载荷字节仍有剩余.自适应字段中额外空间采用填充字节填满.
	if header.AdaptionFieldControl >= 2 {
		// adaptationFieldLength