Index: p2p/client/basicportallocator.cc |
diff --git a/p2p/client/basicportallocator.cc b/p2p/client/basicportallocator.cc |
index 32941f34677d8cd65a3c8b7573a256ba355cc38a..e00638032734ea2b1e36ad33cb0b9d534eb4d830 100644 |
--- a/p2p/client/basicportallocator.cc |
+++ b/p2p/client/basicportallocator.cc |
@@ -43,9 +43,8 @@ enum { |
const int PHASE_UDP = 0; |
const int PHASE_RELAY = 1; |
const int PHASE_TCP = 2; |
-const int PHASE_SSLTCP = 3; |
-const int kNumPhases = 4; |
+const int kNumPhases = 3; |
// Gets protocol priority: UDP > TCP > SSLTCP == TLS. |
int GetProtocolPriority(cricket::ProtocolType protocol) { |
@@ -408,11 +407,6 @@ void BasicPortAllocatorSession::GetCandidatesFromPort( |
if (!CheckCandidateFilter(candidate)) { |
continue; |
} |
- ProtocolType pvalue; |
- if (!StringToProto(candidate.protocol().c_str(), &pvalue) || |
- !data.sequence()->ProtocolEnabled(pvalue)) { |
- continue; |
- } |
candidates->push_back(SanitizeRelatedAddress(candidate)); |
} |
} |
@@ -817,18 +811,10 @@ void BasicPortAllocatorSession::OnCandidateReady( |
} |
} |
- ProtocolType pvalue; |
- bool candidate_protocol_enabled = |
- StringToProto(c.protocol().c_str(), &pvalue) && |
- data->sequence()->ProtocolEnabled(pvalue); |
- |
- if (data->ready() && CheckCandidateFilter(c) && candidate_protocol_enabled) { |
+ if (data->ready() && CheckCandidateFilter(c)) { |
std::vector<Candidate> candidates; |
candidates.push_back(SanitizeRelatedAddress(c)); |
SignalCandidatesReady(this, candidates); |
- } else if (!candidate_protocol_enabled) { |
- LOG(LS_INFO) |
- << "Not yet signaling candidate because protocol is not yet enabled."; |
} else { |
LOG(LS_INFO) << "Discarding candidate because it doesn't match filter."; |
} |
@@ -925,36 +911,6 @@ void BasicPortAllocatorSession::OnPortError(Port* port) { |
MaybeSignalCandidatesAllocationDone(); |
} |
-void BasicPortAllocatorSession::OnProtocolEnabled(AllocationSequence* seq, |
- ProtocolType proto) { |
- std::vector<Candidate> candidates; |
- for (std::vector<PortData>::iterator it = ports_.begin(); |
- it != ports_.end(); ++it) { |
- if (it->sequence() != seq) |
- continue; |
- |
- const std::vector<Candidate>& potentials = it->port()->Candidates(); |
- for (size_t i = 0; i < potentials.size(); ++i) { |
- if (!CheckCandidateFilter(potentials[i])) { |
- continue; |
- } |
- ProtocolType pvalue; |
- bool candidate_protocol_enabled = |
- StringToProto(potentials[i].protocol().c_str(), &pvalue) && |
- pvalue == proto; |
- if (candidate_protocol_enabled) { |
- LOG(LS_INFO) << "Signaling candidate because protocol was enabled: " |
- << potentials[i].ToSensitiveString(); |
- candidates.push_back(potentials[i]); |
- } |
- } |
- } |
- |
- if (!candidates.empty()) { |
- SignalCandidatesReady(this, candidates); |
- } |
-} |
- |
bool BasicPortAllocatorSession::CheckCandidateFilter(const Candidate& c) const { |
uint32_t filter = candidate_filter_; |
@@ -1189,9 +1145,7 @@ void AllocationSequence::OnMessage(rtc::Message* msg) { |
RTC_DCHECK(rtc::Thread::Current() == session_->network_thread()); |
RTC_DCHECK(msg->message_id == MSG_ALLOCATION_PHASE); |
- const char* const PHASE_NAMES[kNumPhases] = { |
- "Udp", "Relay", "Tcp", "SslTcp" |
- }; |
+ const char* const PHASE_NAMES[kNumPhases] = {"Udp", "Relay", "Tcp"}; |
// Perform all of the phases in the current step. |
LOG_J(LS_INFO, network_) << "Allocation Phase=" |
@@ -1201,7 +1155,6 @@ void AllocationSequence::OnMessage(rtc::Message* msg) { |
case PHASE_UDP: |
CreateUDPPorts(); |
CreateStunPorts(); |
- EnableProtocol(PROTO_UDP); |
break; |
case PHASE_RELAY: |
@@ -1210,12 +1163,7 @@ void AllocationSequence::OnMessage(rtc::Message* msg) { |
case PHASE_TCP: |
CreateTCPPorts(); |
- EnableProtocol(PROTO_TCP); |
- break; |
- |
- case PHASE_SSLTCP: |
state_ = kCompleted; |
- EnableProtocol(PROTO_SSLTCP); |
break; |
default: |
@@ -1235,22 +1183,6 @@ void AllocationSequence::OnMessage(rtc::Message* msg) { |
} |
} |
-void AllocationSequence::EnableProtocol(ProtocolType proto) { |
- if (!ProtocolEnabled(proto)) { |
- protocols_.push_back(proto); |
- session_->OnProtocolEnabled(this, proto); |
- } |
-} |
- |
-bool AllocationSequence::ProtocolEnabled(ProtocolType proto) const { |
- for (ProtocolList::const_iterator it = protocols_.begin(); |
- it != protocols_.end(); ++it) { |
- if (*it == proto) |
- return true; |
- } |
- return false; |
-} |
- |
void AllocationSequence::CreateUDPPorts() { |
if (IsFlagSet(PORTALLOCATOR_DISABLE_UDP)) { |
LOG(LS_VERBOSE) << "AllocationSequence: UDP ports disabled, skipping."; |