Initialise and use ChannelMojo to the service utility process.

chrome/service/service_process.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 "chrome/service/service_process.h"
 
 #include <algorithm>
 
 #include "base/base_switches.h"
 #include "base/callback.h"
@@ skipping 20 matching lines @@
 #include "chrome/common/pref_names.h"
 #include "chrome/common/service_process_util.h"
 #include "chrome/grit/chromium_strings.h"
 #include "chrome/grit/generated_resources.h"
 #include "chrome/service/cloud_print/cloud_print_message_handler.h"
 #include "chrome/service/cloud_print/cloud_print_proxy.h"
 #include "chrome/service/net/service_url_request_context_getter.h"
 #include "chrome/service/service_process_prefs.h"
 #include "components/network_session_configurator/switches.h"
 #include "components/prefs/json_pref_store.h"
+#include "mojo/edk/embedder/embedder.h"
+#include "mojo/edk/embedder/scoped_ipc_support.h"
 #include "net/base/network_change_notifier.h"
 #include "net/url_request/url_fetcher.h"
 #include "ui/base/l10n/l10n_util.h"
 #include "ui/base/material_design/material_design_controller.h"
 #include "ui/base/resource/resource_bundle.h"
 #include "ui/base/ui_base_switches.h"
 
 #if defined(USE_GLIB)
 #include <glib-object.h>
 #endif
@@ skipping 96 matching lines @@
   io_thread_.reset(new ServiceIOThread("ServiceProcess_IO"));
   file_thread_.reset(new base::Thread("ServiceProcess_File"));
   if (!io_thread_->StartWithOptions(options) ||
       !file_thread_->StartWithOptions(options)) {
     NOTREACHED();
     Teardown();
     return false;
   }
   blocking_pool_ = new base::SequencedWorkerPool(3, "ServiceBlocking");
 
+  // Initialize Mojo early so things can use it.
+  mojo::edk::Init();
+  mojo_ipc_support_.reset(
+      new mojo::edk::ScopedIPCSupport(io_thread_->task_runner()));
+
   request_context_getter_ = new ServiceURLRequestContextGetter();
 
   base::FilePath user_data_dir;
   PathService::Get(chrome::DIR_USER_DATA, &user_data_dir);
   base::FilePath pref_path =
       user_data_dir.Append(chrome::kServiceStateFileName);
   service_prefs_.reset(new ServiceProcessPrefs(
       pref_path,
       JsonPrefStore::GetTaskRunnerForFile(pref_path, blocking_pool_.get())
           .get()));
@@ skipping 51 matching lines @@
   // See if we need to stay running.
   ScheduleShutdownCheck();
 
   return true;
 }
 
 bool ServiceProcess::Teardown() {
   service_prefs_.reset();
   cloud_print_proxy_.reset();
 
+  mojo_ipc_support_.reset();
   ipc_server_.reset();
   // Signal this event before shutting down the service process. That way all
   // background threads can cleanup.
   shutdown_event_.Signal();
   io_thread_.reset();
   file_thread_.reset();
 
   if (blocking_pool_.get()) {
     // The goal is to make it impossible for chrome to 'infinite loop' during
     // shutdown, but to reasonably expect that all BLOCKING_SHUTDOWN tasks
@@ skipping 130 matching lines @@
     } else {
       Shutdown();
     }
   }
 }
 
 ServiceProcess::~ServiceProcess() {
   Teardown();
   g_service_process = NULL;
 }