| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "media/cast/rtp_receiver/rtp_parser/test/rtp_packet_builder.h" | 5 #include "media/cast/rtp_receiver/rtp_parser/test/rtp_packet_builder.h" |
| 6 | 6 |
| 7 #include "base/big_endian.h" | 7 #include "base/big_endian.h" |
| 8 #include "base/logging.h" | 8 #include "base/logging.h" |
| 9 | 9 |
| 10 namespace media { | 10 namespace media { |
| 11 namespace cast { | 11 namespace cast { |
| 12 | 12 |
| 13 const uint32 kCastRtpHeaderLength = 7; | 13 const uint32 kCastRtpHeaderLength = 7; |
| 14 const uint32 kGenericRtpHeaderLength = 12; | 14 const uint32 kGenericRtpHeaderLength = 12; |
| 15 static const uint8 kRtpMarkerBitMask = 0x80; | 15 static const uint8 kRtpMarkerBitMask = 0x80; |
| 16 | 16 |
| 17 RtpPacketBuilder::RtpPacketBuilder() | 17 RtpPacketBuilder::RtpPacketBuilder() |
| 18 : is_key_(false), | 18 : is_key_(false), |
| 19 frame_id_(0), | 19 frame_id_(0), |
| 20 packet_id_(0), | 20 packet_id_(0), |
| 21 max_packet_id_(0), | 21 max_packet_id_(0), |
| 22 reference_frame_id_(0), | 22 reference_frame_id_(0), |
| 23 is_reference_set_(false), | |
| 24 timestamp_(0), | 23 timestamp_(0), |
| 25 sequence_number_(0), | 24 sequence_number_(0), |
| 26 marker_(false), | 25 marker_(false), |
| 27 payload_type_(0), | 26 payload_type_(0), |
| 28 ssrc_(0) {} | 27 ssrc_(0) {} |
| 29 | 28 |
| 30 void RtpPacketBuilder::SetKeyFrame(bool is_key) { is_key_ = is_key; } | 29 void RtpPacketBuilder::SetKeyFrame(bool is_key) { is_key_ = is_key; } |
| 31 | 30 |
| 32 void RtpPacketBuilder::SetFrameId(uint32 frame_id) { frame_id_ = frame_id; } | 31 void RtpPacketBuilder::SetFrameIds(uint32 frame_id, uint32 reference_frame_id) { |
| 32 frame_id_ = frame_id; |
| 33 reference_frame_id_ = reference_frame_id; |
| 34 } |
| 33 | 35 |
| 34 void RtpPacketBuilder::SetPacketId(uint16 packet_id) { packet_id_ = packet_id; } | 36 void RtpPacketBuilder::SetPacketId(uint16 packet_id) { packet_id_ = packet_id; } |
| 35 | 37 |
| 36 void RtpPacketBuilder::SetMaxPacketId(uint16 max_packet_id) { | 38 void RtpPacketBuilder::SetMaxPacketId(uint16 max_packet_id) { |
| 37 max_packet_id_ = max_packet_id; | 39 max_packet_id_ = max_packet_id; |
| 38 } | 40 } |
| 39 | 41 |
| 40 void RtpPacketBuilder::SetReferenceFrameId(uint32 reference_frame_id, | |
| 41 bool is_set) { | |
| 42 is_reference_set_ = is_set; | |
| 43 if (is_set) | |
| 44 reference_frame_id_ = reference_frame_id; | |
| 45 } | |
| 46 void RtpPacketBuilder::SetTimestamp(uint32 timestamp) { | 42 void RtpPacketBuilder::SetTimestamp(uint32 timestamp) { |
| 47 timestamp_ = timestamp; | 43 timestamp_ = timestamp; |
| 48 } | 44 } |
| 49 | 45 |
| 50 void RtpPacketBuilder::SetSequenceNumber(uint16 sequence_number) { | 46 void RtpPacketBuilder::SetSequenceNumber(uint16 sequence_number) { |
| 51 sequence_number_ = sequence_number; | 47 sequence_number_ = sequence_number; |
| 52 } | 48 } |
| 53 | 49 |
| 54 void RtpPacketBuilder::SetMarkerBit(bool marker) { marker_ = marker; } | 50 void RtpPacketBuilder::SetMarkerBit(bool marker) { marker_ = marker; } |
| 55 | 51 |
| 56 void RtpPacketBuilder::SetPayloadType(int payload_type) { | 52 void RtpPacketBuilder::SetPayloadType(int payload_type) { |
| 57 payload_type_ = payload_type; | 53 payload_type_ = payload_type; |
| 58 } | 54 } |
| 59 | 55 |
| 60 void RtpPacketBuilder::SetSsrc(uint32 ssrc) { ssrc_ = ssrc; } | 56 void RtpPacketBuilder::SetSsrc(uint32 ssrc) { ssrc_ = ssrc; } |
| 61 | 57 |
| 62 void RtpPacketBuilder::BuildHeader(uint8* data, uint32 data_length) { | 58 void RtpPacketBuilder::BuildHeader(uint8* data, uint32 data_length) { |
| 63 BuildCommonHeader(data, data_length); | 59 BuildCommonHeader(data, data_length); |
| 64 BuildCastHeader(data + kGenericRtpHeaderLength, | 60 BuildCastHeader(data + kGenericRtpHeaderLength, |
| 65 data_length - kGenericRtpHeaderLength); | 61 data_length - kGenericRtpHeaderLength); |
| 66 } | 62 } |
| 67 | 63 |
| 68 void RtpPacketBuilder::BuildCastHeader(uint8* data, uint32 data_length) { | 64 void RtpPacketBuilder::BuildCastHeader(uint8* data, uint32 data_length) { |
| 69 // Build header. | 65 // Build header. |
| 70 DCHECK_LE(kCastRtpHeaderLength, data_length); | 66 DCHECK_LE(kCastRtpHeaderLength, data_length); |
| 71 // Set the first 7 bytes to 0. | 67 // Set the first 7 bytes to 0. |
| 72 memset(data, 0, kCastRtpHeaderLength); | 68 memset(data, 0, kCastRtpHeaderLength); |
| 73 base::BigEndianWriter big_endian_writer(reinterpret_cast<char*>(data), 56); | 69 base::BigEndianWriter big_endian_writer(reinterpret_cast<char*>(data), 56); |
| 70 const bool includes_specific_frame_reference = |
| 71 (is_key_ && (reference_frame_id_ != frame_id_)) || |
| 72 (!is_key_ && (reference_frame_id_ != (frame_id_ - 1))); |
| 74 big_endian_writer.WriteU8((is_key_ ? 0x80 : 0) | | 73 big_endian_writer.WriteU8((is_key_ ? 0x80 : 0) | |
| 75 (is_reference_set_ ? 0x40 : 0)); | 74 (includes_specific_frame_reference ? 0x40 : 0)); |
| 76 big_endian_writer.WriteU8(frame_id_); | 75 big_endian_writer.WriteU8(frame_id_); |
| 77 big_endian_writer.WriteU16(packet_id_); | 76 big_endian_writer.WriteU16(packet_id_); |
| 78 big_endian_writer.WriteU16(max_packet_id_); | 77 big_endian_writer.WriteU16(max_packet_id_); |
| 79 if (is_reference_set_) { | 78 if (includes_specific_frame_reference) { |
| 80 big_endian_writer.WriteU8(reference_frame_id_); | 79 big_endian_writer.WriteU8(reference_frame_id_); |
| 81 } | 80 } |
| 82 } | 81 } |
| 83 | 82 |
| 84 void RtpPacketBuilder::BuildCommonHeader(uint8* data, uint32 data_length) { | 83 void RtpPacketBuilder::BuildCommonHeader(uint8* data, uint32 data_length) { |
| 85 DCHECK_LE(kGenericRtpHeaderLength, data_length); | 84 DCHECK_LE(kGenericRtpHeaderLength, data_length); |
| 86 base::BigEndianWriter big_endian_writer(reinterpret_cast<char*>(data), 96); | 85 base::BigEndianWriter big_endian_writer(reinterpret_cast<char*>(data), 96); |
| 87 big_endian_writer.WriteU8(0x80); | 86 big_endian_writer.WriteU8(0x80); |
| 88 big_endian_writer.WriteU8(payload_type_ | (marker_ ? kRtpMarkerBitMask : 0)); | 87 big_endian_writer.WriteU8(payload_type_ | (marker_ ? kRtpMarkerBitMask : 0)); |
| 89 big_endian_writer.WriteU16(sequence_number_); | 88 big_endian_writer.WriteU16(sequence_number_); |
| 90 big_endian_writer.WriteU32(timestamp_); | 89 big_endian_writer.WriteU32(timestamp_); |
| 91 big_endian_writer.WriteU32(ssrc_); | 90 big_endian_writer.WriteU32(ssrc_); |
| 92 } | 91 } |
| 93 | 92 |
| 94 } // namespace cast | 93 } // namespace cast |
| 95 } // namespace media | 94 } // namespace media |
| OLD | NEW |