Create an experiment to study whether too many bindings cause NAT failure

content/renderer/media/webrtc/peer_connection_dependency_factory.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/renderer/media/webrtc/peer_connection_dependency_factory.h"
 
 #include <vector>
 
 #include "base/command_line.h"
 #include "base/location.h"
@@ skipping 638 matching lines @@
   *thread = jingle_glue::JingleThreadWrapper::current();
   event->Signal();
 }
 
 void PeerConnectionDependencyFactory::TryScheduleStunProbeTrial() {
   const base::CommandLine* cmd_line = base::CommandLine::ForCurrentProcess();
 
   if (!cmd_line->HasSwitch(switches::kWebRtcStunProbeTrialParameter))
     return;
 
-  GetPcFactory();
-
   // The underneath IPC channel has to be connected before sending any IPC
   // message.
   if (!p2p_socket_dispatcher_->connected()) {
     base::MessageLoop::current()->PostDelayedTask(
         FROM_HERE,
         base::Bind(&PeerConnectionDependencyFactory::TryScheduleStunProbeTrial,
                    base::Unretained(this)),
         base::TimeDelta::FromSeconds(1));
     return;
   }
 
+  // GetPcFactory could trigger an IPC message. If done before
+  // |p2p_socket_dispatcher_| is connected, that'll put the
+  // |p2p_socket_dispatcher_| in a bad state such that no other IPC message can
+  // be processed.
+  GetPcFactory();
+
   const std::string params =
       cmd_line->GetSwitchValueASCII(switches::kWebRtcStunProbeTrialParameter);
 
   chrome_worker_thread_.task_runner()->PostDelayedTask(
       FROM_HERE,
       base::Bind(
           &PeerConnectionDependencyFactory::StartStunProbeTrialOnWorkerThread,
           base::Unretained(this), params),
       base::TimeDelta::FromMilliseconds(kExperimentStartDelayMs));
 }
 
 void PeerConnectionDependencyFactory::StartStunProbeTrialOnWorkerThread(
     const std::string& params) {
+  DCHECK(network_manager_);
   DCHECK(chrome_worker_thread_.task_runner()->BelongsToCurrentThread());
-  rtc::NetworkManager::NetworkList networks;
-  network_manager_->GetNetworks(&networks);
-  stun_prober_ = StartStunProbeTrial(networks, params, socket_factory_.get());
+  stun_trial_.reset(
+      new StunProberTrial(network_manager_, params, socket_factory_.get()));
 }
 
 void PeerConnectionDependencyFactory::CreateIpcNetworkManagerOnWorkerThread(
     base::WaitableEvent* event) {
   DCHECK(chrome_worker_thread_.task_runner()->BelongsToCurrentThread());
   network_manager_ = new IpcNetworkManager(p2p_socket_dispatcher_.get());
   event->Signal();
 }
 
 void PeerConnectionDependencyFactory::DeleteIpcNetworkManager() {
@@ skipping 56 matching lines @@
 }
 
 void PeerConnectionDependencyFactory::EnsureWebRtcAudioDeviceImpl() {
   if (audio_device_.get())
     return;
 
   audio_device_ = new WebRtcAudioDeviceImpl();
 }
 
 }  // namespace content