15d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)// Copyright 2014 The Chromium Authors. All rights reserved. 268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)// found in the LICENSE file. 468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 55d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "media/formats/mp2t/ts_section_pes.h" 668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)#include "base/logging.h" 868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)#include "base/strings/string_number_conversions.h" 968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)#include "media/base/bit_reader.h" 1068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)#include "media/base/buffers.h" 115d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "media/formats/mp2t/es_parser.h" 125d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "media/formats/mp2t/mp2t_common.h" 131320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#include "media/formats/mp2t/timestamp_unroller.h" 1468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 1568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)static const int kPesStartCode = 0x000001; 1668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 1768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)static bool IsTimestampSectionValid(int64 timestamp_section) { 1868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // |pts_section| has 40 bits: 1968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // - starting with either '0010' or '0011' or '0001' 2068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // - and ending with a marker bit. 2168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // See ITU H.222 standard - PES section. 2268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 2368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Verify that all the marker bits are set to one. 2468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) return ((timestamp_section & 0x1) != 0) && 2568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) ((timestamp_section & 0x10000) != 0) && 2668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) ((timestamp_section & 0x100000000) != 0); 2768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)} 2868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 2968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)static int64 ConvertTimestampSectionToTimestamp(int64 timestamp_section) { 3068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) return (((timestamp_section >> 33) & 0x7) << 30) | 3168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) (((timestamp_section >> 17) & 0x7fff) << 15) | 3268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) (((timestamp_section >> 1) & 0x7fff) << 0); 3368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)} 3468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 3568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)namespace media { 3668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)namespace mp2t { 3768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 381320f92c476a1ad9d19dba2a48c72b75566198e9Primiano TucciTsSectionPes::TsSectionPes(scoped_ptr<EsParser> es_parser, 391320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci TimestampUnroller* timestamp_unroller) 4068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) : es_parser_(es_parser.release()), 4168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) wait_for_pusi_(true), 421320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci timestamp_unroller_(timestamp_unroller) { 4368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) DCHECK(es_parser_); 441320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci DCHECK(timestamp_unroller_); 4568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)} 4668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 4768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)TsSectionPes::~TsSectionPes() { 4868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)} 4968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 5068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)bool TsSectionPes::Parse(bool payload_unit_start_indicator, 5168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) const uint8* buf, int size) { 5268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Ignore partial PES. 5368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if (wait_for_pusi_ && !payload_unit_start_indicator) 5468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) return true; 5568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 5668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) bool parse_result = true; 5768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if (payload_unit_start_indicator) { 5868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Try emitting a packet since we might have a pending PES packet 5968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // with an undefined size. 6068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // In this case, a unit is emitted when the next unit is coming. 6168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int raw_pes_size; 6268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) const uint8* raw_pes; 6368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) pes_byte_queue_.Peek(&raw_pes, &raw_pes_size); 6468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if (raw_pes_size > 0) 6568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) parse_result = Emit(true); 6668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 6768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Reset the state. 6868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) ResetPesState(); 6968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 7068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Update the state. 7168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) wait_for_pusi_ = false; 7268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) } 7368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 7468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Add the data to the parser state. 7568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if (size > 0) 7668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) pes_byte_queue_.Push(buf, size); 7768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 7868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Try emitting the current PES packet. 7968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) return (parse_result && Emit(false)); 8068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)} 8168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 8268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)void TsSectionPes::Flush() { 8368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Try emitting a packet since we might have a pending PES packet 8468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // with an undefined size. 8568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) Emit(true); 8668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 8768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Flush the underlying ES parser. 8868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) es_parser_->Flush(); 8968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)} 9068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 9168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)void TsSectionPes::Reset() { 9268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) ResetPesState(); 9368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) es_parser_->Reset(); 9468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)} 9568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 9668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)bool TsSectionPes::Emit(bool emit_for_unknown_size) { 9768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int raw_pes_size; 9868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) const uint8* raw_pes; 9968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) pes_byte_queue_.Peek(&raw_pes, &raw_pes_size); 10068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 10168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // A PES should be at least 6 bytes. 10268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Wait for more data to come if not enough bytes. 10368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if (raw_pes_size < 6) 10468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) return true; 10568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 10668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Check whether we have enough data to start parsing. 10768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int pes_packet_length = 10868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) (static_cast<int>(raw_pes[4]) << 8) | 10968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) (static_cast<int>(raw_pes[5])); 11068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if ((pes_packet_length == 0 && !emit_for_unknown_size) || 11168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) (pes_packet_length != 0 && raw_pes_size < pes_packet_length + 6)) { 11268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Wait for more data to come either because: 11368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // - there are not enough bytes, 11468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // - or the PES size is unknown and the "force emit" flag is not set. 11568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // (PES size might be unknown for video PES packet). 11668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) return true; 11768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) } 11868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) DVLOG(LOG_LEVEL_PES) << "pes_packet_length=" << pes_packet_length; 11968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 12068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Parse the packet. 12168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) bool parse_result = ParseInternal(raw_pes, raw_pes_size); 12268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 12368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Reset the state. 12468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) ResetPesState(); 12568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 12668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) return parse_result; 12768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)} 12868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 12968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)bool TsSectionPes::ParseInternal(const uint8* raw_pes, int raw_pes_size) { 13068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) BitReader bit_reader(raw_pes, raw_pes_size); 13168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 13268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Read up to the pes_packet_length (6 bytes). 13368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int packet_start_code_prefix; 13468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int stream_id; 13568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int pes_packet_length; 13668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(24, &packet_start_code_prefix)); 13768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(8, &stream_id)); 13868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(16, &pes_packet_length)); 13968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 14068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(packet_start_code_prefix == kPesStartCode); 14168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) DVLOG(LOG_LEVEL_PES) << "stream_id=" << std::hex << stream_id << std::dec; 14268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if (pes_packet_length == 0) 14368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) pes_packet_length = bit_reader.bits_available() / 8; 14468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 14568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Ignore the PES for unknown stream IDs. 14668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // See ITU H.222 Table 2-22 "Stream_id assignments" 14768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) bool is_audio_stream_id = ((stream_id & 0xe0) == 0xc0); 14868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) bool is_video_stream_id = ((stream_id & 0xf0) == 0xe0); 14968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if (!is_audio_stream_id && !is_video_stream_id) 15068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) return true; 15168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 15268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Read up to "pes_header_data_length". 15368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int dummy_2; 15468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int PES_scrambling_control; 15568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int PES_priority; 15668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int data_alignment_indicator; 15768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int copyright; 15868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int original_or_copy; 15968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int pts_dts_flags; 16068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int escr_flag; 16168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int es_rate_flag; 16268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int dsm_trick_mode_flag; 16368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int additional_copy_info_flag; 16468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int pes_crc_flag; 16568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int pes_extension_flag; 16668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int pes_header_data_length; 16768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(2, &dummy_2)); 16868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(dummy_2 == 0x2); 16968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(2, &PES_scrambling_control)); 17068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(1, &PES_priority)); 17168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(1, &data_alignment_indicator)); 17268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(1, ©right)); 17368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(1, &original_or_copy)); 17468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(2, &pts_dts_flags)); 17568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(1, &escr_flag)); 17668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(1, &es_rate_flag)); 17768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(1, &dsm_trick_mode_flag)); 17868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(1, &additional_copy_info_flag)); 17968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(1, &pes_crc_flag)); 18068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(1, &pes_extension_flag)); 18168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(8, &pes_header_data_length)); 18268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int pes_header_start_size = bit_reader.bits_available() / 8; 18368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 18468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Compute the size and the offset of the ES payload. 18568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // "6" for the 6 bytes read before and including |pes_packet_length|. 18668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // "3" for the 3 bytes read before and including |pes_header_data_length|. 18768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int es_size = pes_packet_length - 3 - pes_header_data_length; 18868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int es_offset = 6 + 3 + pes_header_data_length; 18968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(es_size >= 0); 19068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(es_offset + es_size <= raw_pes_size); 19168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 19268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Read the timing information section. 19368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) bool is_pts_valid = false; 19468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) bool is_dts_valid = false; 19568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int64 pts_section = 0; 19668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int64 dts_section = 0; 19768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if (pts_dts_flags == 0x2) { 19868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(40, &pts_section)); 19968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK((((pts_section >> 36) & 0xf) == 0x2) && 20068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) IsTimestampSectionValid(pts_section)); 20168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) is_pts_valid = true; 20268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) } 20368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if (pts_dts_flags == 0x3) { 20468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(40, &pts_section)); 20568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(bit_reader.ReadBits(40, &dts_section)); 20668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK((((pts_section >> 36) & 0xf) == 0x3) && 20768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) IsTimestampSectionValid(pts_section)); 20868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK((((dts_section >> 36) & 0xf) == 0x1) && 20968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) IsTimestampSectionValid(dts_section)); 21068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) is_pts_valid = true; 21168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) is_dts_valid = true; 21268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) } 21368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 21468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Convert and unroll the timestamps. 21568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) base::TimeDelta media_pts(kNoTimestamp()); 2166e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) DecodeTimestamp media_dts(kNoDecodeTimestamp()); 21768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if (is_pts_valid) { 2181320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci int64 pts = timestamp_unroller_->GetUnrolledTimestamp( 2191320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci ConvertTimestampSectionToTimestamp(pts_section)); 22068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) media_pts = base::TimeDelta::FromMicroseconds((1000 * pts) / 90); 22168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) } 22268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if (is_dts_valid) { 2231320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci int64 dts = timestamp_unroller_->GetUnrolledTimestamp( 2241320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci ConvertTimestampSectionToTimestamp(dts_section)); 2256e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) media_dts = DecodeTimestamp::FromMicroseconds((1000 * dts) / 90); 22668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) } 22768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 22868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Discard the rest of the PES packet header. 22968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // TODO(damienv): check if some info of the PES packet header are useful. 23068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) DCHECK_EQ(bit_reader.bits_available() % 8, 0); 23168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) int pes_header_remaining_size = pes_header_data_length - 23268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) (pes_header_start_size - bit_reader.bits_available() / 8); 23368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RCHECK(pes_header_remaining_size >= 0); 23468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 23568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // Read the PES packet. 23668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) DVLOG(LOG_LEVEL_PES) 23768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) << "Emit a reassembled PES:" 23868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) << " size=" << es_size 23968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) << " pts=" << media_pts.InMilliseconds() 24068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) << " dts=" << media_dts.InMilliseconds() 24168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) << " data_alignment_indicator=" << data_alignment_indicator; 24268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) return es_parser_->Parse(&raw_pes[es_offset], es_size, media_pts, media_dts); 24368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)} 24468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 24568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)void TsSectionPes::ResetPesState() { 24668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) pes_byte_queue_.Reset(); 24768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) wait_for_pusi_ = true; 24868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)} 24968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 25068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)} // namespace mp2t 25168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)} // namespace media 252