[Chromoting] Introducing refcount-based life time management of the message loops in the service (d…

remoting/host/chromoting_host_context.cc

Index: remoting/host/chromoting_host_context.cc
diff --git a/remoting/host/chromoting_host_context.cc b/remoting/host/chromoting_host_context.cc
index 480de732922a9282de5dac6a984b884150f6f2ec..08c74b1d334bd75384eb62cb6e78a90c30557495 100644
--- a/remoting/host/chromoting_host_context.cc
+++ b/remoting/host/chromoting_host_context.cc
@@ -8,12 +8,13 @@
 
 #include "base/bind.h"
 #include "base/threading/thread.h"
+#include "remoting/base/auto_thread_task_runner.h"
 #include "remoting/host/url_request_context.h"
 
 namespace remoting {
 
 ChromotingHostContext::ChromotingHostContext(
-    scoped_refptr<base::SingleThreadTaskRunner> ui_task_runner)
+    base::SingleThreadTaskRunner* ui_task_runner)
     : network_thread_("ChromotingNetworkThread"),
       capture_thread_("ChromotingCaptureThread"),
       encode_thread_("ChromotingEncodeThread"),
@@ -36,6 +37,22 @@ bool ChromotingHostContext::Start() {
   if (!started)
     return false;
 
+  network_task_runner_ =
+      new AutoThreadTaskRunner(ui_task_runner_,
+                               network_thread_.message_loop_proxy());
+  capture_task_runner_ =
+      new AutoThreadTaskRunner(ui_task_runner_,
+                               capture_thread_.message_loop_proxy());
+  encode_task_runner_ =
+      new AutoThreadTaskRunner(ui_task_runner_,
+                               encode_thread_.message_loop_proxy());
+  desktop_task_runner_ =
+      new AutoThreadTaskRunner(ui_task_runner_,
+                               desktop_thread_.message_loop_proxy());
+  file_task_runner_ =
+      new AutoThreadTaskRunner(ui_task_runner_,
+                               file_thread_.message_loop_proxy());
+
   url_request_context_getter_ = new URLRequestContextGetter(
       ui_task_runner(), network_task_runner(),
       static_cast<MessageLoopForIO*>(file_thread_.message_loop()));
@@ -43,19 +60,19 @@ bool ChromotingHostContext::Start() {
 }
 
 base::SingleThreadTaskRunner* ChromotingHostContext::capture_task_runner() {
-  return capture_thread_.message_loop_proxy();
+  return capture_task_runner_;
 }
 
 base::SingleThreadTaskRunner* ChromotingHostContext::encode_task_runner() {
-  return encode_thread_.message_loop_proxy();
+  return encode_task_runner_;
 }
 
 base::SingleThreadTaskRunner* ChromotingHostContext::network_task_runner() {
-  return network_thread_.message_loop_proxy();
+  return network_task_runner_;
 }
 
 base::SingleThreadTaskRunner* ChromotingHostContext::desktop_task_runner() {
-  return desktop_thread_.message_loop_proxy();
+  return desktop_task_runner_;
 }
 
 base::SingleThreadTaskRunner* ChromotingHostContext::ui_task_runner() {
@@ -63,7 +80,7 @@ base::SingleThreadTaskRunner* ChromotingHostContext::ui_task_runner() {
 }
 
 base::SingleThreadTaskRunner* ChromotingHostContext::file_task_runner() {
-  return file_thread_.message_loop_proxy();
+  return file_task_runner_;
 }
 
 const scoped_refptr<net::URLRequestContextGetter>&