Enable WebRTC support in the remoting host.

remoting/host/chromoting_host.cc

 // Copyright (c) 2012 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 "remoting/host/chromoting_host.h"
 
 #include <algorithm>
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/command_line.h"
 #include "build/build_config.h"
 #include "jingle/glue/thread_wrapper.h"
 #include "remoting/base/constants.h"
 #include "remoting/base/logging.h"
 #include "remoting/host/chromoting_host_context.h"
 #include "remoting/host/desktop_environment.h"
 #include "remoting/host/host_config.h"
 #include "remoting/host/input_injector.h"
 #include "remoting/host/video_frame_recorder.h"
 #include "remoting/protocol/client_stub.h"
 #include "remoting/protocol/host_stub.h"
 #include "remoting/protocol/ice_connection_to_client.h"
 #include "remoting/protocol/input_stub.h"
+#include "remoting/protocol/webrtc_connection_to_client.h"
 
 using remoting::protocol::ConnectionToClient;
 using remoting::protocol::InputStub;
 
 namespace remoting {
 
 namespace {
 
 const net::BackoffEntry::Policy kDefaultBackoffPolicy = {
   // Number of initial errors (in sequence) to ignore before applying
@@ skipping 231 matching lines @@
     LOG(WARNING) << "Rejecting connection due to"
                     " an overload of failed login attempts.";
     *response = protocol::SessionManager::OVERLOAD;
     return;
   }
 
   *response = protocol::SessionManager::ACCEPT;
 
   HOST_LOG << "Client connected: " << session->jid();
 
-  // Create a client object.
-  scoped_ptr<protocol::ConnectionToClient> connection(
-      new protocol::IceConnectionToClient(make_scoped_ptr(session),
-                                          video_encode_task_runner_));
+  // Create either IceConnectionToClient or WebrtcConnectionToClient.
+  // TODO(sergeyu): Move this logic to the protocol layer.
+  scoped_ptr<protocol::ConnectionToClient> connection;
+  if (session->config().protocol() ==
+      protocol::SessionConfig::Protocol::WEBRTC) {
+    connection.reset(
+        new protocol::WebrtcConnectionToClient(make_scoped_ptr(session)));
+  } else {
+    connection.reset(new protocol::IceConnectionToClient(
+        make_scoped_ptr(session), video_encode_task_runner_));
+  }
+
+  // Create a ClientSession object.
   ClientSession* client = new ClientSession(
-      this,
-      audio_task_runner_,
-      input_task_runner_,
-      video_capture_task_runner_,
-      video_encode_task_runner_,
-      network_task_runner_,
-      ui_task_runner_,
-      connection.Pass(),
-      desktop_environment_factory_,
-      max_session_duration_,
-      pairing_registry_,
-      extensions_.get());
+      this, audio_task_runner_, input_task_runner_, video_capture_task_runner_,
+      video_encode_task_runner_, network_task_runner_, ui_task_runner_,
+      connection.Pass(), desktop_environment_factory_, max_session_duration_,
+      pairing_registry_, extensions_.get());
 
   clients_.push_back(client);
 }
 
 void ChromotingHost::DisconnectAllClients() {
   DCHECK(CalledOnValidThread());
 
   while (!clients_.empty()) {
     size_t size = clients_.size();
     clients_.front()->DisconnectSession(protocol::OK);
     CHECK_EQ(clients_.size(), size - 1);
   }
 }
 
 }  // namespace remoting