Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1578)

Side by Side Diff: media/cast/transport/rtcp/rtcp_builder.cc

Issue 145873006: ui/base/resource: Roll our own version of ReadBigEndian() function. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: base/big_endian Created 6 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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/transport/rtcp/rtcp_builder.h" 5 #include "media/cast/transport/rtcp/rtcp_builder.h"
6 6
7 #include <algorithm> 7 #include <algorithm>
8 #include <string> 8 #include <string>
9 #include <vector> 9 #include <vector>
10 10
11 #include "base/big_endian.h"
11 #include "base/logging.h" 12 #include "base/logging.h"
12 #include "media/cast/transport/cast_transport_defines.h" 13 #include "media/cast/transport/cast_transport_defines.h"
13 #include "media/cast/transport/pacing/paced_sender.h" 14 #include "media/cast/transport/pacing/paced_sender.h"
14 #include "net/base/big_endian.h"
15 15
16 static const size_t kRtcpCastLogHeaderSize = 12; 16 static const size_t kRtcpCastLogHeaderSize = 12;
17 static const size_t kRtcpSenderFrameLogSize = 4; 17 static const size_t kRtcpSenderFrameLogSize = 4;
18 18
19 namespace media { 19 namespace media {
20 namespace cast { 20 namespace cast {
21 namespace transport { 21 namespace transport {
22 22
23 namespace { 23 namespace {
24 // RFC 3550 page 44, including end null. 24 // RFC 3550 page 44, including end null.
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after
76 void RtcpBuilder::BuildSR(const RtcpSenderInfo& sender_info, 76 void RtcpBuilder::BuildSR(const RtcpSenderInfo& sender_info,
77 Packet* packet) const { 77 Packet* packet) const {
78 // Sender report. 78 // Sender report.
79 size_t start_size = packet->size(); 79 size_t start_size = packet->size();
80 DCHECK_LT(start_size + 52, kMaxIpPacketSize) << "Not enough buffer space"; 80 DCHECK_LT(start_size + 52, kMaxIpPacketSize) << "Not enough buffer space";
81 if (start_size + 52 > kMaxIpPacketSize) return; 81 if (start_size + 52 > kMaxIpPacketSize) return;
82 82
83 uint16 number_of_rows = 6; 83 uint16 number_of_rows = 6;
84 packet->resize(start_size + 28); 84 packet->resize(start_size + 28);
85 85
86 net::BigEndianWriter big_endian_writer(&((*packet)[start_size]), 28); 86 base::BigEndianWriter big_endian_writer(&((*packet)[start_size]), 28);
87 big_endian_writer.WriteU8(0x80); 87 big_endian_writer.WriteU8(0x80);
88 big_endian_writer.WriteU8(kPacketTypeSenderReport); 88 big_endian_writer.WriteU8(kPacketTypeSenderReport);
89 big_endian_writer.WriteU16(number_of_rows); 89 big_endian_writer.WriteU16(number_of_rows);
90 big_endian_writer.WriteU32(ssrc_); 90 big_endian_writer.WriteU32(ssrc_);
91 big_endian_writer.WriteU32(sender_info.ntp_seconds); 91 big_endian_writer.WriteU32(sender_info.ntp_seconds);
92 big_endian_writer.WriteU32(sender_info.ntp_fraction); 92 big_endian_writer.WriteU32(sender_info.ntp_fraction);
93 big_endian_writer.WriteU32(sender_info.rtp_timestamp); 93 big_endian_writer.WriteU32(sender_info.rtp_timestamp);
94 big_endian_writer.WriteU32(sender_info.send_packet_count); 94 big_endian_writer.WriteU32(sender_info.send_packet_count);
95 big_endian_writer.WriteU32(static_cast<uint32>(sender_info.send_octet_count)); 95 big_endian_writer.WriteU32(static_cast<uint32>(sender_info.send_octet_count));
96 } 96 }
97 97
98 void RtcpBuilder::BuildSdec(Packet* packet) const { 98 void RtcpBuilder::BuildSdec(Packet* packet) const {
99 size_t start_size = packet->size(); 99 size_t start_size = packet->size();
100 DCHECK_LT(start_size + 12 + c_name_.length(), kMaxIpPacketSize) 100 DCHECK_LT(start_size + 12 + c_name_.length(), kMaxIpPacketSize)
101 << "Not enough buffer space"; 101 << "Not enough buffer space";
102 if (start_size + 12 > kMaxIpPacketSize) return; 102 if (start_size + 12 > kMaxIpPacketSize) return;
103 103
104 // SDES Source Description. 104 // SDES Source Description.
105 packet->resize(start_size + 10); 105 packet->resize(start_size + 10);
106 106
107 net::BigEndianWriter big_endian_writer(&((*packet)[start_size]), 10); 107 base::BigEndianWriter big_endian_writer(&((*packet)[start_size]), 10);
108 // We always need to add one SDES CNAME. 108 // We always need to add one SDES CNAME.
109 big_endian_writer.WriteU8(0x80 + 1); 109 big_endian_writer.WriteU8(0x80 + 1);
110 big_endian_writer.WriteU8(kPacketTypeSdes); 110 big_endian_writer.WriteU8(kPacketTypeSdes);
111 111
112 // Handle SDES length later on. 112 // Handle SDES length later on.
113 uint32 sdes_length_position = static_cast<uint32>(start_size) + 3; 113 uint32 sdes_length_position = static_cast<uint32>(start_size) + 3;
114 big_endian_writer.WriteU16(0); 114 big_endian_writer.WriteU16(0);
115 big_endian_writer.WriteU32(ssrc_); // Add our own SSRC. 115 big_endian_writer.WriteU32(ssrc_); // Add our own SSRC.
116 big_endian_writer.WriteU8(1); // CNAME = 1 116 big_endian_writer.WriteU8(1); // CNAME = 1
117 big_endian_writer.WriteU8(static_cast<uint8>(c_name_.length())); 117 big_endian_writer.WriteU8(static_cast<uint8>(c_name_.length()));
(...skipping 20 matching lines...) Expand all
138 (*packet)[sdes_length_position] = buffer_length; 138 (*packet)[sdes_length_position] = buffer_length;
139 } 139 }
140 140
141 void RtcpBuilder::BuildBye(Packet* packet) const { 141 void RtcpBuilder::BuildBye(Packet* packet) const {
142 size_t start_size = packet->size(); 142 size_t start_size = packet->size();
143 DCHECK_LT(start_size + 8, kMaxIpPacketSize) << "Not enough buffer space"; 143 DCHECK_LT(start_size + 8, kMaxIpPacketSize) << "Not enough buffer space";
144 if (start_size + 8 > kMaxIpPacketSize) return; 144 if (start_size + 8 > kMaxIpPacketSize) return;
145 145
146 packet->resize(start_size + 8); 146 packet->resize(start_size + 8);
147 147
148 net::BigEndianWriter big_endian_writer(&((*packet)[start_size]), 8); 148 base::BigEndianWriter big_endian_writer(&((*packet)[start_size]), 8);
149 big_endian_writer.WriteU8(0x80 + 1); 149 big_endian_writer.WriteU8(0x80 + 1);
150 big_endian_writer.WriteU8(kPacketTypeBye); 150 big_endian_writer.WriteU8(kPacketTypeBye);
151 big_endian_writer.WriteU16(1); // Length. 151 big_endian_writer.WriteU16(1); // Length.
152 big_endian_writer.WriteU32(ssrc_); // Add our own SSRC. 152 big_endian_writer.WriteU32(ssrc_); // Add our own SSRC.
153 } 153 }
154 154
155 /* 155 /*
156 0 1 2 3 156 0 1 2 3
157 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 157 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
158 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 158 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
(...skipping 11 matching lines...) Expand all
170 +=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ 170 +=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
171 */ 171 */
172 void RtcpBuilder::BuildDlrrRb(const RtcpDlrrReportBlock& dlrr, 172 void RtcpBuilder::BuildDlrrRb(const RtcpDlrrReportBlock& dlrr,
173 Packet* packet) const { 173 Packet* packet) const {
174 size_t start_size = packet->size(); 174 size_t start_size = packet->size();
175 DCHECK_LT(start_size + 24, kMaxIpPacketSize) << "Not enough buffer space"; 175 DCHECK_LT(start_size + 24, kMaxIpPacketSize) << "Not enough buffer space";
176 if (start_size + 24 > kMaxIpPacketSize) return; 176 if (start_size + 24 > kMaxIpPacketSize) return;
177 177
178 packet->resize(start_size + 24); 178 packet->resize(start_size + 24);
179 179
180 net::BigEndianWriter big_endian_writer(&((*packet)[start_size]), 24); 180 base::BigEndianWriter big_endian_writer(&((*packet)[start_size]), 24);
181 big_endian_writer.WriteU8(0x80); 181 big_endian_writer.WriteU8(0x80);
182 big_endian_writer.WriteU8(kPacketTypeXr); 182 big_endian_writer.WriteU8(kPacketTypeXr);
183 big_endian_writer.WriteU16(5); // Length. 183 big_endian_writer.WriteU16(5); // Length.
184 big_endian_writer.WriteU32(ssrc_); // Add our own SSRC. 184 big_endian_writer.WriteU32(ssrc_); // Add our own SSRC.
185 big_endian_writer.WriteU8(5); // Add block type. 185 big_endian_writer.WriteU8(5); // Add block type.
186 big_endian_writer.WriteU8(0); // Add reserved. 186 big_endian_writer.WriteU8(0); // Add reserved.
187 big_endian_writer.WriteU16(3); // Block length. 187 big_endian_writer.WriteU16(3); // Block length.
188 big_endian_writer.WriteU32(ssrc_); // Add the media (received RTP) SSRC. 188 big_endian_writer.WriteU32(ssrc_); // Add the media (received RTP) SSRC.
189 big_endian_writer.WriteU32(dlrr.last_rr); 189 big_endian_writer.WriteU32(dlrr.last_rr);
190 big_endian_writer.WriteU32(dlrr.delay_since_last_rr); 190 big_endian_writer.WriteU32(dlrr.delay_since_last_rr);
(...skipping 11 matching lines...) Expand all
202 202
203 size_t space_for_x_messages = 203 size_t space_for_x_messages =
204 (remaining_space - kRtcpCastLogHeaderSize) / kRtcpSenderFrameLogSize; 204 (remaining_space - kRtcpCastLogHeaderSize) / kRtcpSenderFrameLogSize;
205 size_t number_of_messages = std::min(space_for_x_messages, 205 size_t number_of_messages = std::min(space_for_x_messages,
206 sender_log_message.size()); 206 sender_log_message.size());
207 207
208 size_t log_size = kRtcpCastLogHeaderSize + 208 size_t log_size = kRtcpCastLogHeaderSize +
209 number_of_messages * kRtcpSenderFrameLogSize; 209 number_of_messages * kRtcpSenderFrameLogSize;
210 packet->resize(start_size + log_size); 210 packet->resize(start_size + log_size);
211 211
212 net::BigEndianWriter big_endian_writer(&((*packet)[start_size]), log_size); 212 base::BigEndianWriter big_endian_writer(&((*packet)[start_size]), log_size);
213 big_endian_writer.WriteU8(0x80 + kSenderLogSubtype); 213 big_endian_writer.WriteU8(0x80 + kSenderLogSubtype);
214 big_endian_writer.WriteU8(kPacketTypeApplicationDefined); 214 big_endian_writer.WriteU8(kPacketTypeApplicationDefined);
215 big_endian_writer.WriteU16(static_cast<uint16>(2 + number_of_messages)); 215 big_endian_writer.WriteU16(static_cast<uint16>(2 + number_of_messages));
216 big_endian_writer.WriteU32(ssrc_); // Add our own SSRC. 216 big_endian_writer.WriteU32(ssrc_); // Add our own SSRC.
217 big_endian_writer.WriteU32(kCast); 217 big_endian_writer.WriteU32(kCast);
218 218
219 std::list<RtcpSenderFrameLogMessage>::const_iterator it = 219 std::list<RtcpSenderFrameLogMessage>::const_iterator it =
220 sender_log_message.begin(); 220 sender_log_message.begin();
221 for (; number_of_messages > 0; --number_of_messages) { 221 for (; number_of_messages > 0; --number_of_messages) {
222 DCHECK(!sender_log_message.empty()); 222 DCHECK(!sender_log_message.empty());
223 const RtcpSenderFrameLogMessage& message = *it; 223 const RtcpSenderFrameLogMessage& message = *it;
224 big_endian_writer.WriteU8(static_cast<uint8>(message.frame_status)); 224 big_endian_writer.WriteU8(static_cast<uint8>(message.frame_status));
225 // We send the 24 east significant bits of the RTP timestamp. 225 // We send the 24 east significant bits of the RTP timestamp.
226 big_endian_writer.WriteU8(static_cast<uint8>(message.rtp_timestamp >> 16)); 226 big_endian_writer.WriteU8(static_cast<uint8>(message.rtp_timestamp >> 16));
227 big_endian_writer.WriteU8(static_cast<uint8>(message.rtp_timestamp >> 8)); 227 big_endian_writer.WriteU8(static_cast<uint8>(message.rtp_timestamp >> 8));
228 big_endian_writer.WriteU8(static_cast<uint8>(message.rtp_timestamp)); 228 big_endian_writer.WriteU8(static_cast<uint8>(message.rtp_timestamp));
229 ++it; 229 ++it;
230 } 230 }
231 } 231 }
232 232
233 } // namespace transport 233 } // namespace transport
234 } // namespace cast 234 } // namespace cast
235 } // namespace media 235 } // namespace media
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698