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