Index: webrtc/p2p/client/basicportallocator.cc |
diff --git a/webrtc/p2p/client/basicportallocator.cc b/webrtc/p2p/client/basicportallocator.cc |
index 143b036183777875730387f85736ed71ad90e3db..bf61bc88fc9612074b6eaa5e387b026645027eb2 100644 |
--- a/webrtc/p2p/client/basicportallocator.cc |
+++ b/webrtc/p2p/client/basicportallocator.cc |
@@ -36,7 +36,6 @@ enum { |
MSG_CONFIG_READY, |
MSG_ALLOCATE, |
MSG_ALLOCATION_PHASE, |
- MSG_SHAKE, |
MSG_SEQUENCEOBJECTS_CREATED, |
MSG_CONFIG_STOP, |
}; |
@@ -48,14 +47,6 @@ const int PHASE_SSLTCP = 3; |
const int kNumPhases = 4; |
-const int SHAKE_MIN_DELAY = 45 * 1000; // 45 seconds |
-const int SHAKE_MAX_DELAY = 90 * 1000; // 90 seconds |
- |
-int ShakeDelay() { |
- int range = SHAKE_MAX_DELAY - SHAKE_MIN_DELAY + 1; |
- return SHAKE_MIN_DELAY + CreateRandomId() % range; |
-} |
- |
} // namespace |
namespace cricket { |
@@ -186,9 +177,6 @@ void BasicPortAllocatorSession::StartGettingPorts() { |
running_ = true; |
network_thread_->Post(this, MSG_CONFIG_START); |
- |
- if (flags() & PORTALLOCATOR_ENABLE_SHAKER) |
- network_thread_->PostDelayed(ShakeDelay(), this, MSG_SHAKE); |
} |
void BasicPortAllocatorSession::StopGettingPorts() { |
@@ -265,21 +253,14 @@ void BasicPortAllocatorSession::OnMessage(rtc::Message *message) { |
ASSERT(rtc::Thread::Current() == network_thread_); |
GetPortConfigurations(); |
break; |
- |
case MSG_CONFIG_READY: |
ASSERT(rtc::Thread::Current() == network_thread_); |
OnConfigReady(static_cast<PortConfiguration*>(message->pdata)); |
break; |
- |
case MSG_ALLOCATE: |
ASSERT(rtc::Thread::Current() == network_thread_); |
OnAllocate(); |
break; |
- |
- case MSG_SHAKE: |
- ASSERT(rtc::Thread::Current() == network_thread_); |
- OnShake(); |
- break; |
case MSG_SEQUENCEOBJECTS_CREATED: |
ASSERT(rtc::Thread::Current() == network_thread_); |
OnAllocationSequenceObjectsCreated(); |
@@ -713,36 +694,6 @@ void BasicPortAllocatorSession::OnPortDestroyed( |
ASSERT(false); |
} |
-void BasicPortAllocatorSession::OnShake() { |
- LOG(INFO) << ">>>>> SHAKE <<<<< >>>>> SHAKE <<<<< >>>>> SHAKE <<<<<"; |
- |
- std::vector<Port*> ports; |
- std::vector<Connection*> connections; |
- |
- for (size_t i = 0; i < ports_.size(); ++i) { |
- if (ports_[i].ready()) |
- ports.push_back(ports_[i].port()); |
- } |
- |
- for (size_t i = 0; i < ports.size(); ++i) { |
- Port::AddressMap::const_iterator iter; |
- for (iter = ports[i]->connections().begin(); |
- iter != ports[i]->connections().end(); |
- ++iter) { |
- connections.push_back(iter->second); |
- } |
- } |
- |
- LOG(INFO) << ">>>>> Destroying " << ports.size() << " ports and " |
- << connections.size() << " connections"; |
- |
- for (size_t i = 0; i < connections.size(); ++i) |
- connections[i]->Destroy(); |
- |
- if (running_ || (ports.size() > 0) || (connections.size() > 0)) |
- network_thread_->PostDelayed(ShakeDelay(), this, MSG_SHAKE); |
-} |
- |
BasicPortAllocatorSession::PortData* BasicPortAllocatorSession::FindPort( |
Port* port) { |
for (std::vector<PortData>::iterator it = ports_.begin(); |