OLD | NEW |
---|---|
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 433 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
444 std::vector<Candidate> candidates; | 444 std::vector<Candidate> candidates; |
445 ProtocolType pvalue; | 445 ProtocolType pvalue; |
446 bool candidate_allowed_to_send = CheckCandidateFilter(c); | 446 bool candidate_allowed_to_send = CheckCandidateFilter(c); |
447 if (StringToProto(c.protocol().c_str(), &pvalue) && | 447 if (StringToProto(c.protocol().c_str(), &pvalue) && |
448 data->sequence()->ProtocolEnabled(pvalue) && | 448 data->sequence()->ProtocolEnabled(pvalue) && |
449 candidate_allowed_to_send) { | 449 candidate_allowed_to_send) { |
450 candidates.push_back(c); | 450 candidates.push_back(c); |
451 } | 451 } |
452 | 452 |
453 if (!candidates.empty()) { | 453 if (!candidates.empty()) { |
454 SignalCandidatesReady(this, candidates); | 454 SignalCandidatesReady(this, candidates); |
juberti1
2015/08/06 00:35:26
Will we push 0.0.0.0 to the application here? We w
pthatcher1
2015/08/06 01:06:19
I believe candidate_allowed_to_send will be false
guoweis_webrtc
2015/08/06 08:50:07
Correct. It'll be filtered out
| |
455 } | 455 } |
456 | 456 |
457 // Moving to READY state as we have atleast one candidate from the port. | 457 // Moving to READY state as we have at least one candidate from the port or |
juberti1
2015/08/06 00:35:26
This comment could be worded better. It's importan
guoweis_webrtc
2015/08/06 08:50:07
Done.
| |
458 // Since this port has atleast one candidate we should forward this port | 458 // the candidate has the any address. When this port has at least one |
459 // to listners, to allow connections from this port. | 459 // candidate we should forward this port to listeners, to allow connections |
460 // Also we should make sure that candidate gathered from this port is allowed | 460 // from this port. Also we should make sure that candidate gathered from this |
461 // to send outside. | 461 // port is allowed to send outside. When the candidate address is the any |
462 if (!data->ready() && candidate_allowed_to_send) { | 462 // address, we need to move the port to READY such that connectivity is |
463 // possible if the remote peer has a routable IP address on public Internet. | |
pthatcher1
2015/08/06 01:06:19
I think we can re-word this in terms of "we're rea
guoweis_webrtc
2015/08/06 08:50:06
Done.
| |
464 if (!data->ready() && (candidate_allowed_to_send || | |
465 (c.address().IsAnyIP() && port->SharedSocket()))) { | |
pthatcher1
2015/08/06 01:06:19
I think this would be a lot more readable if we br
guoweis_webrtc
2015/08/06 08:50:07
I rephrase it a bit. Send and Receive is not very
| |
463 data->set_ready(); | 466 data->set_ready(); |
464 SignalPortReady(this, port); | 467 SignalPortReady(this, port); |
465 } | 468 } |
466 } | 469 } |
467 | 470 |
468 void BasicPortAllocatorSession::OnPortComplete(Port* port) { | 471 void BasicPortAllocatorSession::OnPortComplete(Port* port) { |
469 ASSERT(rtc::Thread::Current() == network_thread_); | 472 ASSERT(rtc::Thread::Current() == network_thread_); |
470 PortData* data = FindPort(port); | 473 PortData* data = FindPort(port); |
471 ASSERT(data != NULL); | 474 ASSERT(data != NULL); |
472 | 475 |
(...skipping 646 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
1119 ServerAddresses servers; | 1122 ServerAddresses servers; |
1120 for (size_t i = 0; i < relays.size(); ++i) { | 1123 for (size_t i = 0; i < relays.size(); ++i) { |
1121 if (relays[i].type == turn_type && SupportsProtocol(relays[i], type)) { | 1124 if (relays[i].type == turn_type && SupportsProtocol(relays[i], type)) { |
1122 servers.insert(relays[i].ports.front().address); | 1125 servers.insert(relays[i].ports.front().address); |
1123 } | 1126 } |
1124 } | 1127 } |
1125 return servers; | 1128 return servers; |
1126 } | 1129 } |
1127 | 1130 |
1128 } // namespace cricket | 1131 } // namespace cricket |
OLD | NEW |