chromecast/browser/cast_browser_main_parts.cc

   1 // Copyright 2014 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 "chromecast/browser/cast_browser_main_parts.h"
   6
   7 #include <string>
   8 #if !defined(OS_ANDROID)
   9 #include <signal.h>
  10 #include <sys/prctl.h>
  11 #endif
  12
  13 #include "base/command_line.h"
  14 #include "base/files/file_util.h"
  15 #include "base/message_loop/message_loop.h"
  16 #include "base/path_service.h"
  17 #include "base/prefs/pref_registry_simple.h"
  18 #include "base/run_loop.h"
  19 #include "base/thread_task_runner_handle.h"
  20 #include "cc/base/switches.h"
  21 #include "chromecast/base/cast_paths.h"
  22 #include "chromecast/base/cast_sys_info_util.h"
  23 #include "chromecast/base/chromecast_switches.h"
  24 #include "chromecast/base/metrics/cast_metrics_helper.h"
  25 #include "chromecast/base/metrics/grouped_histogram.h"
  26 #include "chromecast/browser/cast_browser_context.h"
  27 #include "chromecast/browser/cast_browser_process.h"
  28 #include "chromecast/browser/devtools/remote_debugging_server.h"
  29 #include "chromecast/browser/metrics/cast_metrics_prefs.h"
  30 #include "chromecast/browser/metrics/cast_metrics_service_client.h"
  31 #include "chromecast/browser/pref_service_helper.h"
  32 #include "chromecast/browser/service/cast_service.h"
  33 #include "chromecast/browser/url_request_context_factory.h"
  34 #include "chromecast/common/platform_client_auth.h"
  35 #include "chromecast/media/base/key_systems_common.h"
  36 #include "chromecast/net/connectivity_checker.h"
  37 #include "chromecast/public/cast_media_shlib.h"
  38 #include "chromecast/public/cast_sys_info.h"
  39 #include "content/public/browser/browser_thread.h"
  40 #include "content/public/browser/gpu_data_manager.h"
  41 #include "content/public/common/content_switches.h"
  42 #include "media/audio/audio_manager.h"
  43 #include "media/audio/audio_manager_factory.h"
  44 #include "media/base/browser_cdm_factory.h"
  45 #include "media/base/media.h"
  46 #include "ui/compositor/compositor_switches.h"
  47
  48 #if defined(OS_ANDROID)
  49 #include "chromecast/browser/media/cast_media_client_android.h"
  50 #include "chromecast/crash/android/crash_handler.h"
  51 #include "components/crash/browser/crash_dump_manager_android.h"
  52 #include "media/base/android/media_client_android.h"
  53 #include "net/android/network_change_notifier_factory_android.h"
  54 #else
  55 #include "chromecast/browser/media/cast_browser_cdm_factory.h"
  56 #include "chromecast/net/network_change_notifier_factory_cast.h"
  57 #endif
  58
  59 #if defined(USE_AURA)
  60 #include "ui/aura/env.h"
  61 #include "ui/aura/test/test_screen.h"
  62 #include "ui/gfx/screen.h"
  63 #endif
  64
  65 namespace {
  66
  67 #if !defined(OS_ANDROID)
  68 int kSignalsToRunClosure[] = { SIGTERM, SIGINT, };
  69
  70 // Closure to run on SIGTERM and SIGINT.
  71 base::Closure* g_signal_closure = NULL;
  72
  73 void RunClosureOnSignal(int signum) {
  74   LOG(ERROR) << "Got signal " << signum;
  75   DCHECK(g_signal_closure);
  76   // Expect main thread got this signal. Otherwise, weak_ptr of run_loop will
  77   // crash the process.
  78   g_signal_closure->Run();
  79 }
  80
  81 void RegisterClosureOnSignal(const base::Closure& closure) {
  82   DCHECK(!g_signal_closure);
  83   DCHECK_GT(arraysize(kSignalsToRunClosure), 0U);
  84
  85   // Allow memory leak by intention.
  86   g_signal_closure = new base::Closure(closure);
  87
  88   struct sigaction sa_new;
  89   memset(&sa_new, 0, sizeof(sa_new));
  90   sa_new.sa_handler = RunClosureOnSignal;
  91   sigfillset(&sa_new.sa_mask);
  92   sa_new.sa_flags = SA_RESTART;
  93
  94   for (size_t i = 0; i < arraysize(kSignalsToRunClosure); i++) {
  95     struct sigaction sa_old;
  96     if (sigaction(kSignalsToRunClosure[i], &sa_new, &sa_old) == -1) {
  97       NOTREACHED();
  98     } else {
  99       DCHECK_EQ(sa_old.sa_handler, SIG_DFL);
 100     }
 101   }
 102
 103   // Get the first signal to exit when the parent process dies.
 104   prctl(PR_SET_PDEATHSIG, kSignalsToRunClosure[0]);
 105 }
 106
 107 const int kKillOnAlarmTimeoutSec = 5;  // 5 seconds
 108
 109 void KillOnAlarm(int signum) {
 110   LOG(ERROR) << "Got alarm signal for termination: " << signum;
 111   raise(SIGKILL);
 112 }
 113
 114 void RegisterKillOnAlarm(int timeout_seconds) {
 115   struct sigaction sa_new;
 116   memset(&sa_new, 0, sizeof(sa_new));
 117   sa_new.sa_handler = KillOnAlarm;
 118   sigfillset(&sa_new.sa_mask);
 119   sa_new.sa_flags = SA_RESTART;
 120
 121   struct sigaction sa_old;
 122   if (sigaction(SIGALRM, &sa_new, &sa_old) == -1) {
 123     NOTREACHED();
 124   } else {
 125     DCHECK_EQ(sa_old.sa_handler, SIG_DFL);
 126   }
 127
 128   if (alarm(timeout_seconds) > 0)
 129     NOTREACHED() << "Previous alarm() was cancelled";
 130 }
 131
 132 void DeregisterKillOnAlarm() {
 133   // Explicitly cancel any outstanding alarm() calls.
 134   alarm(0);
 135
 136   struct sigaction sa_new;
 137   memset(&sa_new, 0, sizeof(sa_new));
 138   sa_new.sa_handler = SIG_DFL;
 139   sigfillset(&sa_new.sa_mask);
 140   sa_new.sa_flags = SA_RESTART;
 141
 142   struct sigaction sa_old;
 143   if (sigaction(SIGALRM, &sa_new, &sa_old) == -1) {
 144     NOTREACHED();
 145   } else {
 146     DCHECK_EQ(sa_old.sa_handler, KillOnAlarm);
 147   }
 148 }
 149 #endif  // !defined(OS_ANDROID)
 150
 151 }  // namespace
 152
 153 namespace chromecast {
 154 namespace shell {
 155
 156 namespace {
 157
 158 struct DefaultCommandLineSwitch {
 159   const char* const switch_name;
 160   const char* const switch_value;
 161 };
 162
 163 DefaultCommandLineSwitch g_default_switches[] = {
 164 #if defined(OS_ANDROID)
 165   // Disables Chromecast-specific WiFi-related features on ATV for now.
 166   { switches::kNoWifi, "" },
 167   { switches::kEnableOverlayFullscreenVideo, ""},
 168   { switches::kDisableGestureRequirementForMediaPlayback, ""},
 169 #endif
 170   // Always enable HTMLMediaElement logs.
 171   { switches::kBlinkPlatformLogChannels, "Media"},
 172 #if defined(DISABLE_DISPLAY)
 173   { switches::kDisableGpu, "" },
 174 #endif
 175 #if defined(OS_LINUX)
 176 #if defined(ARCH_CPU_X86_FAMILY)
 177   // This is needed for now to enable the egltest Ozone platform to work with
 178   // current Linux/NVidia OpenGL drivers.
 179   { switches::kIgnoreGpuBlacklist, ""},
 180 #elif defined(ARCH_CPU_ARM_FAMILY) && !defined(DISABLE_DISPLAY)
 181   // On Linux arm, enable CMA pipeline by default.
 182   { switches::kEnableCmaMediaPipeline, "" },
 183   { switches::kEnableHardwareOverlays, "" },
 184 #endif
 185 #endif  // defined(OS_LINUX)
 186   // Needed to fix a bug where the raster thread doesn't get scheduled for a
 187   // substantial time (~5 seconds).  See https://crbug.com/441895.
 188   { switches::kUseNormalPriorityForTileTaskWorkerThreads, "" },
 189   { NULL, NULL },  // Termination
 190 };
 191
 192 void AddDefaultCommandLineSwitches(base::CommandLine* command_line) {
 193   int i = 0;
 194   while (g_default_switches[i].switch_name != NULL) {
 195     command_line->AppendSwitchASCII(
 196         std::string(g_default_switches[i].switch_name),
 197         std::string(g_default_switches[i].switch_value));
 198     ++i;
 199   }
 200 }
 201
 202 }  // namespace
 203
 204 CastBrowserMainParts::CastBrowserMainParts(
 205     const content::MainFunctionParams& parameters,
 206     URLRequestContextFactory* url_request_context_factory,
 207     scoped_ptr<::media::AudioManagerFactory> audio_manager_factory)
 208     : BrowserMainParts(),
 209       cast_browser_process_(new CastBrowserProcess()),
 210       parameters_(parameters),
 211       url_request_context_factory_(url_request_context_factory),
 212       audio_manager_factory_(audio_manager_factory.Pass()) {
 213   base::CommandLine* command_line = base::CommandLine::ForCurrentProcess();
 214   AddDefaultCommandLineSwitches(command_line);
 215 }
 216
 217 CastBrowserMainParts::~CastBrowserMainParts() {
 218 }
 219
 220 void CastBrowserMainParts::PreMainMessageLoopStart() {
 221   // GroupedHistograms needs to be initialized before any threads are created
 222   // to prevent race conditions between calls to Preregister and those threads
 223   // attempting to collect metrics.
 224   // This call must also be before NetworkChangeNotifier, as it generates
 225   // Net/DNS metrics.
 226   metrics::PreregisterAllGroupedHistograms();
 227
 228   // Set the platform's implementation of AudioManagerFactory.
 229   if (audio_manager_factory_)
 230     ::media::AudioManager::SetFactory(audio_manager_factory_.release());
 231
 232 #if defined(OS_ANDROID)
 233   net::NetworkChangeNotifier::SetFactory(
 234       new net::NetworkChangeNotifierFactoryAndroid());
 235 #else
 236   net::NetworkChangeNotifier::SetFactory(
 237       new NetworkChangeNotifierFactoryCast());
 238 #endif  // defined(OS_ANDROID)
 239 }
 240
 241 void CastBrowserMainParts::PostMainMessageLoopStart() {
 242   cast_browser_process_->SetMetricsHelper(make_scoped_ptr(
 243       new metrics::CastMetricsHelper(base::ThreadTaskRunnerHandle::Get())));
 244
 245 #if defined(OS_ANDROID)
 246   base::MessageLoopForUI::current()->Start();
 247 #endif  // defined(OS_ANDROID)
 248 }
 249
 250 int CastBrowserMainParts::PreCreateThreads() {
 251 #if defined(OS_ANDROID)
 252   // GPU process is started immediately after threads are created, requiring
 253   // CrashDumpManager to be initialized beforehand.
 254   base::FilePath crash_dumps_dir;
 255   if (!chromecast::CrashHandler::GetCrashDumpLocation(&crash_dumps_dir)) {
 256     LOG(ERROR) << "Could not find crash dump location.";
 257   }
 258   cast_browser_process_->SetCrashDumpManager(
 259       make_scoped_ptr(new breakpad::CrashDumpManager(crash_dumps_dir)));
 260 #else
 261   base::FilePath home_dir;
 262   CHECK(PathService::Get(DIR_CAST_HOME, &home_dir));
 263   if (!base::CreateDirectory(home_dir))
 264     return 1;
 265 #endif
 266
 267 #if defined(USE_AURA)
 268   // Screen can (and should) exist even with no displays connected. Its presence
 269   // is assumed as an interface to access display information, e.g. from metrics
 270   // code.  See CastContentWindow::CreateWindowTree for update when resolution
 271   // is available.
 272   DCHECK(!gfx::Screen::GetScreenByType(gfx::SCREEN_TYPE_NATIVE));
 273   gfx::Screen::SetScreenInstance(gfx::SCREEN_TYPE_NATIVE,
 274                                  aura::TestScreen::Create(gfx::Size(0, 0)));
 275 #endif
 276   return 0;
 277 }
 278
 279 void CastBrowserMainParts::PreMainMessageLoopRun() {
 280 #if !defined(OS_ANDROID)
 281   // Set GL strings so GPU config code can make correct feature blacklisting/
 282   // whitelisting decisions.
 283   // Note: SetGLStrings MUST be called after GpuDataManager::Initialize.
 284   scoped_ptr<CastSysInfo> sys_info = CreateSysInfo();
 285   content::GpuDataManager::GetInstance()->SetGLStrings(
 286       sys_info->GetGlVendor(), sys_info->GetGlRenderer(),
 287       sys_info->GetGlVersion());
 288 #endif  // !defined(OS_ANDROID)
 289
 290   scoped_refptr<PrefRegistrySimple> pref_registry(new PrefRegistrySimple());
 291   metrics::RegisterPrefs(pref_registry.get());
 292   cast_browser_process_->SetPrefService(
 293       PrefServiceHelper::CreatePrefService(pref_registry.get()));
 294
 295   const base::CommandLine* cmd_line = base::CommandLine::ForCurrentProcess();
 296 #if defined(OS_ANDROID)
 297   ::media::SetMediaClientAndroid(new media::CastMediaClientAndroid());
 298 #else
 299   if (cmd_line->HasSwitch(switches::kEnableCmaMediaPipeline))
 300     ::media::SetBrowserCdmFactory(new media::CastBrowserCdmFactory());
 301 #endif  // defined(OS_ANDROID)
 302
 303   cast_browser_process_->SetConnectivityChecker(
 304       ConnectivityChecker::Create(
 305           content::BrowserThread::GetMessageLoopProxyForThread(
 306               content::BrowserThread::IO)));
 307
 308   url_request_context_factory_->InitializeOnUIThread();
 309
 310   cast_browser_process_->SetBrowserContext(
 311       make_scoped_ptr(new CastBrowserContext(url_request_context_factory_)));
 312   cast_browser_process_->SetMetricsServiceClient(
 313       metrics::CastMetricsServiceClient::Create(
 314           content::BrowserThread::GetBlockingPool(),
 315           cast_browser_process_->pref_service(),
 316           cast_browser_process_->browser_context()->GetRequestContext()));
 317
 318   if (!PlatformClientAuth::Initialize())
 319     LOG(ERROR) << "PlatformClientAuth::Initialize failed.";
 320
 321   cast_browser_process_->SetRemoteDebuggingServer(
 322       make_scoped_ptr(new RemoteDebuggingServer()));
 323
 324   media::CastMediaShlib::Initialize(cmd_line->argv());
 325   ::media::InitializeMediaLibrary();
 326
 327   cast_browser_process_->SetCastService(CastService::Create(
 328       cast_browser_process_->browser_context(),
 329       cast_browser_process_->pref_service(),
 330       cast_browser_process_->metrics_service_client(),
 331       url_request_context_factory_->GetSystemGetter()));
 332   cast_browser_process_->cast_service()->Initialize();
 333
 334   // Initializing metrics service and network delegates must happen after cast
 335   // service is intialized because CastMetricsServiceClient and
 336   // CastNetworkDelegate may use components initialized by cast service.
 337   cast_browser_process_->metrics_service_client()
 338       ->Initialize(cast_browser_process_->cast_service());
 339   url_request_context_factory_->InitializeNetworkDelegates();
 340
 341   cast_browser_process_->cast_service()->Start();
 342 }
 343
 344 bool CastBrowserMainParts::MainMessageLoopRun(int* result_code) {
 345 #if defined(OS_ANDROID)
 346   // Android does not use native main MessageLoop.
 347   NOTREACHED();
 348   return true;
 349 #else
 350   base::RunLoop run_loop;
 351   base::Closure quit_closure(run_loop.QuitClosure());
 352   RegisterClosureOnSignal(quit_closure);
 353
 354   // If parameters_.ui_task is not NULL, we are running browser tests.
 355   if (parameters_.ui_task) {
 356     base::MessageLoop* message_loop = base::MessageLoopForUI::current();
 357     message_loop->PostTask(FROM_HERE, *parameters_.ui_task);
 358     message_loop->PostTask(FROM_HERE, quit_closure);
 359   }
 360
 361   run_loop.Run();
 362
 363   // Once the main loop has stopped running, we give the browser process a few
 364   // seconds to stop cast service and finalize all resources. If a hang occurs
 365   // and cast services refuse to terminate successfully, then we SIGKILL the
 366   // current process to avoid indefinte hangs.
 367   RegisterKillOnAlarm(kKillOnAlarmTimeoutSec);
 368
 369   cast_browser_process_->cast_service()->Stop();
 370   return true;
 371 #endif
 372 }
 373
 374 void CastBrowserMainParts::PostMainMessageLoopRun() {
 375 #if defined(OS_ANDROID)
 376   // Android does not use native main MessageLoop.
 377   NOTREACHED();
 378 #else
 379   cast_browser_process_->cast_service()->Finalize();
 380   cast_browser_process_->metrics_service_client()->Finalize();
 381   cast_browser_process_.reset();
 382
 383 #if defined(USE_AURA)
 384   aura::Env::DeleteInstance();
 385 #endif
 386
 387   DeregisterKillOnAlarm();
 388 #endif
 389
 390   media::CastMediaShlib::Finalize();
 391 }
 392
 393 }  // namespace shell
 394 }  // namespace chromecast