apps/app_shim/app_shim_host_manager_mac.mm

   1 // Copyright 2013 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "apps/app_shim/app_shim_host_manager_mac.h"
   6
   7 #include "apps/app_shim/app_shim_handler_mac.h"
   8 #include "apps/app_shim/app_shim_host_mac.h"
   9 #include "base/bind.h"
  10 #include "base/command_line.h"
  11 #include "base/files/file_path.h"
  12 #include "base/logging.h"
  13 #include "base/path_service.h"
  14 #include "chrome/browser/browser_process.h"
  15 #include "chrome/common/chrome_paths.h"
  16 #include "chrome/common/chrome_switches.h"
  17 #include "chrome/common/mac/app_mode_common.h"
  18 #include "ipc/unix_domain_socket_util.h"
  19
  20 using content::BrowserThread;
  21
  22 namespace {
  23
  24 void CreateAppShimHost(const IPC::ChannelHandle& handle) {
  25   // AppShimHost takes ownership of itself.
  26   (new AppShimHost)->ServeChannel(handle);
  27 }
  28
  29 }  // namespace
  30
  31 const base::FilePath* AppShimHostManager::g_override_user_data_dir_ = NULL;
  32
  33 AppShimHostManager::AppShimHostManager() {}
  34
  35 void AppShimHostManager::Init() {
  36   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
  37   apps::AppShimHandler::SetDefaultHandler(&extension_app_shim_handler_);
  38   BrowserThread::PostTask(
  39       BrowserThread::FILE, FROM_HERE,
  40       base::Bind(&AppShimHostManager::InitOnFileThread, this));
  41 }
  42
  43 AppShimHostManager::~AppShimHostManager() {
  44   apps::AppShimHandler::SetDefaultHandler(NULL);
  45 }
  46
  47 void AppShimHostManager::InitOnFileThread() {
  48   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
  49   base::FilePath user_data_dir;
  50   if (g_override_user_data_dir_) {
  51     user_data_dir = *g_override_user_data_dir_;
  52   } else if (!PathService::Get(chrome::DIR_USER_DATA, &user_data_dir)) {
  53     LOG(ERROR) << "Couldn't get user data directory while creating App Shim "
  54                << "Host manager.";
  55     return;
  56   }
  57
  58   base::FilePath socket_path =
  59       user_data_dir.Append(app_mode::kAppShimSocketName);
  60   // This mirrors a check in unix_domain_socket_util.cc which will guarantee
  61   // failure and spam log files on bots because they have deeply nested paths to
  62   // |user_data_dir| when swarming. See http://crbug.com/240554. Shim tests that
  63   // run on the bots must override the path using AppShimHostManagerTestApi.
  64   if (socket_path.value().length() >= IPC::kMaxSocketNameLength &&
  65       CommandLine::ForCurrentProcess()->HasSwitch(switches::kTestType)) {
  66     return;
  67   }
  68
  69   factory_.reset(new IPC::ChannelFactory(socket_path, this));
  70   BrowserThread::PostTask(
  71       BrowserThread::IO, FROM_HERE,
  72       base::Bind(&AppShimHostManager::ListenOnIOThread, this));
  73 }
  74
  75 void AppShimHostManager::ListenOnIOThread() {
  76   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
  77   if (!factory_->Listen()) {
  78     BrowserThread::PostTask(
  79         BrowserThread::UI, FROM_HERE,
  80         base::Bind(&AppShimHostManager::OnListenError, this));
  81   }
  82 }
  83
  84 void AppShimHostManager::OnClientConnected(
  85     const IPC::ChannelHandle& handle) {
  86   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
  87   BrowserThread::PostTask(
  88       BrowserThread::UI, FROM_HERE,
  89       base::Bind(&CreateAppShimHost, handle));
  90 }
  91
  92 void AppShimHostManager::OnListenError() {
  93   // TODO(tapted): Set a timeout and attempt to reconstruct the channel. Until
  94   // cases where the error could occur are better known, just reset the factory
  95   // to allow failure to be communicated via the test API.
  96   factory_.reset();
  97 }