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

Side by Side Diff: webrtc/p2p/base/stunport.cc

Issue 1277263002: Add instrumentation to track the IceEndpointType. (Closed) Base URL: https://chromium.googlesource.com/external/webrtc@master
Patch Set: Created 5 years, 4 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
OLDNEW
1 /* 1 /*
2 * Copyright 2004 The WebRTC Project Authors. All rights reserved. 2 * Copyright 2004 The WebRTC Project Authors. All rights reserved.
3 * 3 *
4 * Use of this source code is governed by a BSD-style license 4 * Use of this source code is governed by a BSD-style license
5 * that can be found in the LICENSE file in the root of the source 5 * that can be found in the LICENSE file in the root of the source
6 * tree. An additional intellectual property rights grant can be found 6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may 7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree. 8 * be found in the AUTHORS file in the root of the source tree.
9 */ 9 */
10 10
(...skipping 262 matching lines...) Expand 10 before | Expand all | Expand 10 after
273 int UDPPort::GetOption(rtc::Socket::Option opt, int* value) { 273 int UDPPort::GetOption(rtc::Socket::Option opt, int* value) {
274 return socket_->GetOption(opt, value); 274 return socket_->GetOption(opt, value);
275 } 275 }
276 276
277 int UDPPort::GetError() { 277 int UDPPort::GetError() {
278 return error_; 278 return error_;
279 } 279 }
280 280
281 void UDPPort::OnLocalAddressReady(rtc::AsyncPacketSocket* socket, 281 void UDPPort::OnLocalAddressReady(rtc::AsyncPacketSocket* socket,
282 const rtc::SocketAddress& address) { 282 const rtc::SocketAddress& address) {
283 AddAddress(address, address, rtc::SocketAddress(), 283 AddAddress(address, address, rtc::SocketAddress(), UDP_PROTOCOL_NAME, "", "",
284 UDP_PROTOCOL_NAME, "", LOCAL_PORT_TYPE, 284 LOCAL_PORT_TYPE, ICE_TYPE_PREFERENCE_HOST, 0, false);
285 ICE_TYPE_PREFERENCE_HOST, 0, false);
286 MaybePrepareStunCandidate(); 285 MaybePrepareStunCandidate();
287 } 286 }
288 287
289 void UDPPort::OnReadPacket( 288 void UDPPort::OnReadPacket(
290 rtc::AsyncPacketSocket* socket, const char* data, size_t size, 289 rtc::AsyncPacketSocket* socket, const char* data, size_t size,
291 const rtc::SocketAddress& remote_addr, 290 const rtc::SocketAddress& remote_addr,
292 const rtc::PacketTime& packet_time) { 291 const rtc::PacketTime& packet_time) {
293 ASSERT(socket == socket_); 292 ASSERT(socket == socket_);
294 ASSERT(!remote_addr.IsUnresolved()); 293 ASSERT(!remote_addr.IsUnresolved());
295 294
(...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after
389 !HasCandidateWithAddress(stun_reflected_addr)) { 388 !HasCandidateWithAddress(stun_reflected_addr)) {
390 389
391 rtc::SocketAddress related_address = socket_->GetLocalAddress(); 390 rtc::SocketAddress related_address = socket_->GetLocalAddress();
392 if (!(candidate_filter() & CF_HOST)) { 391 if (!(candidate_filter() & CF_HOST)) {
393 // If candidate filter doesn't have CF_HOST specified, empty raddr to 392 // If candidate filter doesn't have CF_HOST specified, empty raddr to
394 // avoid local address leakage. 393 // avoid local address leakage.
395 related_address = rtc::EmptySocketAddressWithFamily( 394 related_address = rtc::EmptySocketAddressWithFamily(
396 related_address.family()); 395 related_address.family());
397 } 396 }
398 397
399 AddAddress(stun_reflected_addr, socket_->GetLocalAddress(), 398 AddAddress(stun_reflected_addr, socket_->GetLocalAddress(), related_address,
400 related_address, UDP_PROTOCOL_NAME, "", 399 UDP_PROTOCOL_NAME, "", "", STUN_PORT_TYPE,
401 STUN_PORT_TYPE, ICE_TYPE_PREFERENCE_SRFLX, 0, false); 400 ICE_TYPE_PREFERENCE_SRFLX, 0, false);
402 } 401 }
403 MaybeSetPortCompleteOrError(); 402 MaybeSetPortCompleteOrError();
404 } 403 }
405 404
406 void UDPPort::OnStunBindingOrResolveRequestFailed( 405 void UDPPort::OnStunBindingOrResolveRequestFailed(
407 const rtc::SocketAddress& stun_server_addr) { 406 const rtc::SocketAddress& stun_server_addr) {
408 if (bind_request_failed_servers_.find(stun_server_addr) != 407 if (bind_request_failed_servers_.find(stun_server_addr) !=
409 bind_request_failed_servers_.end()) { 408 bind_request_failed_servers_.end()) {
410 return; 409 return;
411 } 410 }
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after
450 const std::vector<Candidate>& existing_candidates = Candidates(); 449 const std::vector<Candidate>& existing_candidates = Candidates();
451 std::vector<Candidate>::const_iterator it = existing_candidates.begin(); 450 std::vector<Candidate>::const_iterator it = existing_candidates.begin();
452 for (; it != existing_candidates.end(); ++it) { 451 for (; it != existing_candidates.end(); ++it) {
453 if (it->address() == addr) 452 if (it->address() == addr)
454 return true; 453 return true;
455 } 454 }
456 return false; 455 return false;
457 } 456 }
458 457
459 } // namespace cricket 458 } // namespace cricket
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698