Remote assistance on Chrome OS Part IV - It2MeHost

remoting/host/chromoting_host_context_impl_chromeos.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_context.h"
+
+#include "chrome/browser/browser_process.h"
+#include "content/public/browser/browser_thread.h"
+#include "net/url_request/url_request_context_getter.h"
+#include "remoting/base/auto_thread.h"
+
+namespace remoting {
+
+namespace {
+// Retrieves the task_runner from the browser thread with |id|.
+AutoThreadTaskRunner* GetTaskRunner(content::BrowserThread::ID id) {
+  return new AutoThreadTaskRunner(
+      content::BrowserThread::GetMessageLoopProxyForThread(id).get(),
+      base::Bind(&base::DoNothing));
+}
+
+class ChromotingHostContextImpl : public ChromotingHostContext {
+ public:
+  ChromotingHostContextImpl(AutoThreadTaskRunner* ui_task_runner);
+
+ private:
+  virtual ~ChromotingHostContextImpl() override;
+};
+
+}  // namespace
+
+// static
+scoped_refptr<ChromotingHostContext> ChromotingHostContext::Create(
+    scoped_refptr<AutoThreadTaskRunner> ui_task_runner) {
+  return new ChromotingHostContextImpl(ui_task_runner.get());
+}
+
+ChromotingHostContextImpl::ChromotingHostContextImpl(
+    AutoThreadTaskRunner* ui_task_runner)
+    : ChromotingHostContext(ui_task_runner) {
+  DCHECK(ui_task_runner_->BelongsToCurrentThread());
+
+  // Thread assignments and re-using existing browser sources
+  // (URLRequestContextGetter) must be performed on the UI thread of the
+  // browser process.
+  file_task_runner_ = GetTaskRunner(content::BrowserThread::FILE);
+  network_task_runner_ = GetTaskRunner(content::BrowserThread::IO);
+  video_capture_task_runner_ = GetTaskRunner(content::BrowserThread::UI);
+
+  // Each instance of BasicURLRequestContext spawns two extra threads.
+  // Reuse the url_request_context_getter of the I/O Thread to avoid creating
+  // extra threads on the UI thread.
+  url_request_context_getter_ = g_browser_process->system_request_context();
+
+  // Thread joining is blocking and it can only be done on threads that allows
+  // blocking I/O.  Uses the |file_task_runner| as the joiner.
+  input_task_runner_ = AutoThread::CreateWithType(
+      "ChromotingInputThread", file_task_runner_, base::MessageLoop::TYPE_IO);
+  audio_task_runner_ = AutoThread::CreateWithType(
+      "ChromotingAudioThread", file_task_runner_, base::MessageLoop::TYPE_IO);
+  video_encode_task_runner_ =
+      AutoThread::Create("ChromotingEncodeThread", file_task_runner_);
+
+}
+
+ChromotingHostContextImpl::~ChromotingHostContextImpl() {
+}
+
+}  // namespace remoting