OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "content/browser/renderer_host/p2p/socket_host.h" | 5 #include "content/browser/renderer_host/p2p/socket_host.h" |
6 | 6 |
7 #include "base/sys_byteorder.h" | 7 #include "base/sys_byteorder.h" |
8 #include "content/browser/renderer_host/p2p/socket_host_tcp.h" | 8 #include "content/browser/renderer_host/p2p/socket_host_tcp.h" |
9 #include "content/browser/renderer_host/p2p/socket_host_tcp_server.h" | 9 #include "content/browser/renderer_host/p2p/socket_host_tcp_server.h" |
10 #include "content/browser/renderer_host/p2p/socket_host_udp.h" | 10 #include "content/browser/renderer_host/p2p/socket_host_udp.h" |
11 #include "content/browser/renderer_host/render_process_host_impl.h" | 11 #include "content/browser/renderer_host/render_process_host_impl.h" |
12 #include "content/public/browser/browser_thread.h" | 12 #include "content/public/browser/browser_thread.h" |
13 #include "crypto/hmac.h" | 13 #include "crypto/hmac.h" |
14 #include "third_party/libjingle/source/talk/base/asyncpacketsocket.h" | |
15 #include "third_party/libjingle/source/talk/base/byteorder.h" | |
16 #include "third_party/libjingle/source/talk/base/messagedigest.h" | |
17 #include "third_party/libjingle/source/talk/p2p/base/stun.h" | 14 #include "third_party/libjingle/source/talk/p2p/base/stun.h" |
| 15 #include "third_party/webrtc/base/asyncpacketsocket.h" |
| 16 #include "third_party/webrtc/base/byteorder.h" |
| 17 #include "third_party/webrtc/base/messagedigest.h" |
18 | 18 |
19 namespace { | 19 namespace { |
20 | 20 |
21 const uint32 kStunMagicCookie = 0x2112A442; | 21 const uint32 kStunMagicCookie = 0x2112A442; |
22 const int kMinRtpHdrLen = 12; | 22 const int kMinRtpHdrLen = 12; |
23 const int kRtpExtnHdrLen = 4; | 23 const int kRtpExtnHdrLen = 4; |
24 const int kDtlsRecordHeaderLen = 13; | 24 const int kDtlsRecordHeaderLen = 13; |
25 const int kTurnChannelHdrLen = 4; | 25 const int kTurnChannelHdrLen = 4; |
26 const int kAbsSendTimeExtnLen = 3; | 26 const int kAbsSendTimeExtnLen = 3; |
27 const int kOneByteHdrLen = 1; | 27 const int kOneByteHdrLen = 1; |
(...skipping 13 matching lines...) Expand all Loading... |
41 const uint8* u = reinterpret_cast<const uint8*>(data); | 41 const uint8* u = reinterpret_cast<const uint8*>(data); |
42 return (len >= kDtlsRecordHeaderLen && (u[0] > 19 && u[0] < 64)); | 42 return (len >= kDtlsRecordHeaderLen && (u[0] > 19 && u[0] < 64)); |
43 } | 43 } |
44 | 44 |
45 bool IsRtcpPacket(const char* data) { | 45 bool IsRtcpPacket(const char* data) { |
46 int type = (static_cast<uint8>(data[1]) & 0x7F); | 46 int type = (static_cast<uint8>(data[1]) & 0x7F); |
47 return (type >= 64 && type < 96); | 47 return (type >= 64 && type < 96); |
48 } | 48 } |
49 | 49 |
50 bool IsTurnSendIndicationPacket(const char* data) { | 50 bool IsTurnSendIndicationPacket(const char* data) { |
51 uint16 type = talk_base::GetBE16(data); | 51 uint16 type = rtc::GetBE16(data); |
52 return (type == cricket::TURN_SEND_INDICATION); | 52 return (type == cricket::TURN_SEND_INDICATION); |
53 } | 53 } |
54 | 54 |
55 bool IsRtpPacket(const char* data, int len) { | 55 bool IsRtpPacket(const char* data, int len) { |
56 return ((*data & 0xC0) == 0x80); | 56 return ((*data & 0xC0) == 0x80); |
57 } | 57 } |
58 | 58 |
59 // Verifies rtp header and message length. | 59 // Verifies rtp header and message length. |
60 bool ValidateRtpHeader(const char* rtp, int length, size_t* header_length) { | 60 bool ValidateRtpHeader(const char* rtp, int length, size_t* header_length) { |
61 if (header_length) | 61 if (header_length) |
(...skipping 11 matching lines...) Expand all Loading... |
73 if (header_length) | 73 if (header_length) |
74 *header_length = rtp_hdr_len_without_extn; | 74 *header_length = rtp_hdr_len_without_extn; |
75 | 75 |
76 return true; | 76 return true; |
77 } | 77 } |
78 | 78 |
79 rtp += rtp_hdr_len_without_extn; | 79 rtp += rtp_hdr_len_without_extn; |
80 | 80 |
81 // Getting extension profile length. | 81 // Getting extension profile length. |
82 // Length is in 32 bit words. | 82 // Length is in 32 bit words. |
83 uint16 extn_length = talk_base::GetBE16(rtp + 2) * 4; | 83 uint16 extn_length = rtc::GetBE16(rtp + 2) * 4; |
84 | 84 |
85 // Verify input length against total header size. | 85 // Verify input length against total header size. |
86 if (rtp_hdr_len_without_extn + kRtpExtnHdrLen + extn_length > length) { | 86 if (rtp_hdr_len_without_extn + kRtpExtnHdrLen + extn_length > length) { |
87 return false; | 87 return false; |
88 } | 88 } |
89 | 89 |
90 if (header_length) | 90 if (header_length) |
91 *header_length = rtp_hdr_len_without_extn + kRtpExtnHdrLen + extn_length; | 91 *header_length = rtp_hdr_len_without_extn + kRtpExtnHdrLen + extn_length; |
92 return true; | 92 return true; |
93 } | 93 } |
(...skipping 28 matching lines...) Expand all Loading... |
122 } | 122 } |
123 // TODO(mallinath) - Add SetBE24 to byteorder.h in libjingle. | 123 // TODO(mallinath) - Add SetBE24 to byteorder.h in libjingle. |
124 extn_data[0] = static_cast<uint8>(now_second >> 16); | 124 extn_data[0] = static_cast<uint8>(now_second >> 16); |
125 extn_data[1] = static_cast<uint8>(now_second >> 8); | 125 extn_data[1] = static_cast<uint8>(now_second >> 8); |
126 extn_data[2] = static_cast<uint8>(now_second); | 126 extn_data[2] = static_cast<uint8>(now_second); |
127 } | 127 } |
128 | 128 |
129 // Assumes |len| is actual packet length + tag length. Updates HMAC at end of | 129 // Assumes |len| is actual packet length + tag length. Updates HMAC at end of |
130 // the RTP packet. | 130 // the RTP packet. |
131 void UpdateRtpAuthTag(char* rtp, int len, | 131 void UpdateRtpAuthTag(char* rtp, int len, |
132 const talk_base::PacketOptions& options) { | 132 const rtc::PacketOptions& options) { |
133 // If there is no key, return. | 133 // If there is no key, return. |
134 if (options.packet_time_params.srtp_auth_key.empty()) | 134 if (options.packet_time_params.srtp_auth_key.empty()) |
135 return; | 135 return; |
136 | 136 |
137 size_t tag_length = options.packet_time_params.srtp_auth_tag_len; | 137 size_t tag_length = options.packet_time_params.srtp_auth_tag_len; |
138 char* auth_tag = rtp + (len - tag_length); | 138 char* auth_tag = rtp + (len - tag_length); |
139 | 139 |
140 // We should have a fake HMAC value @ auth_tag. | 140 // We should have a fake HMAC value @ auth_tag. |
141 DCHECK_EQ(0, memcmp(auth_tag, kFakeAuthTag, tag_length)); | 141 DCHECK_EQ(0, memcmp(auth_tag, kFakeAuthTag, tag_length)); |
142 | 142 |
(...skipping 26 matching lines...) Expand all Loading... |
169 memcpy(auth_tag, output, tag_length); | 169 memcpy(auth_tag, output, tag_length); |
170 } | 170 } |
171 | 171 |
172 } // namespace | 172 } // namespace |
173 | 173 |
174 namespace content { | 174 namespace content { |
175 | 175 |
176 namespace packet_processing_helpers { | 176 namespace packet_processing_helpers { |
177 | 177 |
178 bool ApplyPacketOptions(char* data, int length, | 178 bool ApplyPacketOptions(char* data, int length, |
179 const talk_base::PacketOptions& options, | 179 const rtc::PacketOptions& options, |
180 uint32 abs_send_time) { | 180 uint32 abs_send_time) { |
181 DCHECK(data != NULL); | 181 DCHECK(data != NULL); |
182 DCHECK(length > 0); | 182 DCHECK(length > 0); |
183 // if there is no valid |rtp_sendtime_extension_id| and |srtp_auth_key| in | 183 // if there is no valid |rtp_sendtime_extension_id| and |srtp_auth_key| in |
184 // PacketOptions, nothing to be updated in this packet. | 184 // PacketOptions, nothing to be updated in this packet. |
185 if (options.packet_time_params.rtp_sendtime_extension_id == -1 && | 185 if (options.packet_time_params.rtp_sendtime_extension_id == -1 && |
186 options.packet_time_params.srtp_auth_key.empty()) { | 186 options.packet_time_params.srtp_auth_key.empty()) { |
187 return true; | 187 return true; |
188 } | 188 } |
189 | 189 |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
232 // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | 232 // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
233 // | | | 233 // | | |
234 // / Application Data / | 234 // / Application Data / |
235 // / / | 235 // / / |
236 // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | 236 // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
237 if (length < kTurnChannelHdrLen) { | 237 if (length < kTurnChannelHdrLen) { |
238 return false; | 238 return false; |
239 } | 239 } |
240 | 240 |
241 rtp_begin = kTurnChannelHdrLen; | 241 rtp_begin = kTurnChannelHdrLen; |
242 rtp_length = talk_base::GetBE16(&packet[2]); | 242 rtp_length = rtc::GetBE16(&packet[2]); |
243 if (length < rtp_length + kTurnChannelHdrLen) { | 243 if (length < rtp_length + kTurnChannelHdrLen) { |
244 return false; | 244 return false; |
245 } | 245 } |
246 } else if (IsTurnSendIndicationPacket(packet)) { | 246 } else if (IsTurnSendIndicationPacket(packet)) { |
247 if (length <= P2PSocketHost::kStunHeaderSize) { | 247 if (length <= P2PSocketHost::kStunHeaderSize) { |
248 // Message must be greater than 20 bytes, if it's carrying any payload. | 248 // Message must be greater than 20 bytes, if it's carrying any payload. |
249 return false; | 249 return false; |
250 } | 250 } |
251 // Validate STUN message length. | 251 // Validate STUN message length. |
252 int stun_msg_len = talk_base::GetBE16(&packet[2]); | 252 int stun_msg_len = rtc::GetBE16(&packet[2]); |
253 if (stun_msg_len + P2PSocketHost::kStunHeaderSize != length) { | 253 if (stun_msg_len + P2PSocketHost::kStunHeaderSize != length) { |
254 return false; | 254 return false; |
255 } | 255 } |
256 | 256 |
257 // First skip mandatory stun header which is of 20 bytes. | 257 // First skip mandatory stun header which is of 20 bytes. |
258 rtp_begin = P2PSocketHost::kStunHeaderSize; | 258 rtp_begin = P2PSocketHost::kStunHeaderSize; |
259 // Loop through STUN attributes until we find STUN DATA attribute. | 259 // Loop through STUN attributes until we find STUN DATA attribute. |
260 const char* start = packet + rtp_begin; | 260 const char* start = packet + rtp_begin; |
261 bool data_attr_present = false; | 261 bool data_attr_present = false; |
262 while ((packet + rtp_begin) - start < stun_msg_len) { | 262 while ((packet + rtp_begin) - start < stun_msg_len) { |
263 // Keep reading STUN attributes until we hit DATA attribute. | 263 // Keep reading STUN attributes until we hit DATA attribute. |
264 // Attribute will be a TLV structure. | 264 // Attribute will be a TLV structure. |
265 // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | 265 // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
266 // | Type | Length | | 266 // | Type | Length | |
267 // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | 267 // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
268 // | Value (variable) .... | 268 // | Value (variable) .... |
269 // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | 269 // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
270 // The value in the length field MUST contain the length of the Value | 270 // The value in the length field MUST contain the length of the Value |
271 // part of the attribute, prior to padding, measured in bytes. Since | 271 // part of the attribute, prior to padding, measured in bytes. Since |
272 // STUN aligns attributes on 32-bit boundaries, attributes whose content | 272 // STUN aligns attributes on 32-bit boundaries, attributes whose content |
273 // is not a multiple of 4 bytes are padded with 1, 2, or 3 bytes of | 273 // is not a multiple of 4 bytes are padded with 1, 2, or 3 bytes of |
274 // padding so that its value contains a multiple of 4 bytes. The | 274 // padding so that its value contains a multiple of 4 bytes. The |
275 // padding bits are ignored, and may be any value. | 275 // padding bits are ignored, and may be any value. |
276 uint16 attr_type, attr_length; | 276 uint16 attr_type, attr_length; |
277 // Getting attribute type and length. | 277 // Getting attribute type and length. |
278 attr_type = talk_base::GetBE16(&packet[rtp_begin]); | 278 attr_type = rtc::GetBE16(&packet[rtp_begin]); |
279 attr_length = talk_base::GetBE16( | 279 attr_length = rtc::GetBE16( |
280 &packet[rtp_begin + sizeof(attr_type)]); | 280 &packet[rtp_begin + sizeof(attr_type)]); |
281 // Checking for bogus attribute length. | 281 // Checking for bogus attribute length. |
282 if (length < attr_length + rtp_begin) { | 282 if (length < attr_length + rtp_begin) { |
283 return false; | 283 return false; |
284 } | 284 } |
285 | 285 |
286 if (attr_type != cricket::STUN_ATTR_DATA) { | 286 if (attr_type != cricket::STUN_ATTR_DATA) { |
287 rtp_begin += sizeof(attr_type) + sizeof(attr_length) + attr_length; | 287 rtp_begin += sizeof(attr_type) + sizeof(attr_length) + attr_length; |
288 if ((attr_length % 4) != 0) { | 288 if ((attr_length % 4) != 0) { |
289 rtp_begin += (4 - (attr_length % 4)); | 289 rtp_begin += (4 - (attr_length % 4)); |
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
346 if (!(rtp[0] & 0x10)) { | 346 if (!(rtp[0] & 0x10)) { |
347 return true; | 347 return true; |
348 } | 348 } |
349 | 349 |
350 int cc_count = rtp[0] & 0x0F; | 350 int cc_count = rtp[0] & 0x0F; |
351 int rtp_hdr_len_without_extn = kMinRtpHdrLen + 4 * cc_count; | 351 int rtp_hdr_len_without_extn = kMinRtpHdrLen + 4 * cc_count; |
352 | 352 |
353 rtp += rtp_hdr_len_without_extn; | 353 rtp += rtp_hdr_len_without_extn; |
354 | 354 |
355 // Getting extension profile ID and length. | 355 // Getting extension profile ID and length. |
356 uint16 profile_id = talk_base::GetBE16(rtp); | 356 uint16 profile_id = rtc::GetBE16(rtp); |
357 // Length is in 32 bit words. | 357 // Length is in 32 bit words. |
358 uint16 extn_length = talk_base::GetBE16(rtp + 2) * 4; | 358 uint16 extn_length = rtc::GetBE16(rtp + 2) * 4; |
359 | 359 |
360 rtp += kRtpExtnHdrLen; // Moving past extn header. | 360 rtp += kRtpExtnHdrLen; // Moving past extn header. |
361 | 361 |
362 bool found = false; | 362 bool found = false; |
363 // WebRTC is using one byte header extension. | 363 // WebRTC is using one byte header extension. |
364 // TODO(mallinath) - Handle two byte header extension. | 364 // TODO(mallinath) - Handle two byte header extension. |
365 if (profile_id == 0xBEDE) { // OneByte extension header | 365 if (profile_id == 0xBEDE) { // OneByte extension header |
366 // 0 | 366 // 0 |
367 // 0 1 2 3 4 5 6 7 | 367 // 0 1 2 3 4 5 6 7 |
368 // +-+-+-+-+-+-+-+-+ | 368 // +-+-+-+-+-+-+-+-+ |
(...skipping 208 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
577 BrowserThread::PostTask(BrowserThread::UI, | 577 BrowserThread::PostTask(BrowserThread::UI, |
578 FROM_HERE, | 578 FROM_HERE, |
579 base::Bind(packet_dump_callback_, | 579 base::Bind(packet_dump_callback_, |
580 Passed(&packet_header), | 580 Passed(&packet_header), |
581 header_length, | 581 header_length, |
582 packet_length, | 582 packet_length, |
583 incoming)); | 583 incoming)); |
584 } | 584 } |
585 | 585 |
586 } // namespace content | 586 } // namespace content |
OLD | NEW |