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 |