| // Copyright 2014 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 "chromecast/browser/cast_browser_main_parts.h" |
| |
| #include <stddef.h> |
| #include <string.h> |
| |
| #include <string> |
| |
| #include "base/command_line.h" |
| #include "base/files/file_util.h" |
| #include "base/macros.h" |
| #include "base/memory/ptr_util.h" |
| #include "base/message_loop/message_loop.h" |
| #include "base/path_service.h" |
| #include "base/run_loop.h" |
| #include "base/thread_task_runner_handle.h" |
| #include "base/threading/thread.h" |
| #include "build/build_config.h" |
| #include "cc/base/switches.h" |
| #include "chromecast/base/cast_constants.h" |
| #include "chromecast/base/cast_paths.h" |
| #include "chromecast/base/cast_sys_info_util.h" |
| #include "chromecast/base/chromecast_switches.h" |
| #include "chromecast/base/metrics/cast_metrics_helper.h" |
| #include "chromecast/base/metrics/grouped_histogram.h" |
| #include "chromecast/browser/cast_browser_context.h" |
| #include "chromecast/browser/cast_browser_process.h" |
| #include "chromecast/browser/cast_content_browser_client.h" |
| #include "chromecast/browser/cast_memory_pressure_monitor.h" |
| #include "chromecast/browser/cast_net_log.h" |
| #include "chromecast/browser/devtools/remote_debugging_server.h" |
| #include "chromecast/browser/metrics/cast_metrics_prefs.h" |
| #include "chromecast/browser/metrics/cast_metrics_service_client.h" |
| #include "chromecast/browser/pref_service_helper.h" |
| #include "chromecast/browser/url_request_context_factory.h" |
| #include "chromecast/chromecast_features.h" |
| #include "chromecast/common/platform_client_auth.h" |
| #include "chromecast/media/base/key_systems_common.h" |
| #include "chromecast/media/base/media_resource_tracker.h" |
| #include "chromecast/media/base/video_plane_controller.h" |
| #include "chromecast/media/cma/backend/media_pipeline_backend_manager.h" |
| #include "chromecast/net/connectivity_checker.h" |
| #include "chromecast/public/cast_media_shlib.h" |
| #include "chromecast/public/cast_sys_info.h" |
| #include "chromecast/service/cast_service.h" |
| #include "components/prefs/pref_registry_simple.h" |
| #include "content/public/browser/browser_thread.h" |
| #include "content/public/browser/child_process_security_policy.h" |
| #include "content/public/browser/gpu_data_manager.h" |
| #include "content/public/browser/storage_partition.h" |
| #include "content/public/common/content_switches.h" |
| #include "gpu/command_buffer/service/gpu_switches.h" |
| #include "media/base/media.h" |
| #include "ui/compositor/compositor_switches.h" |
| |
| #if !defined(OS_ANDROID) |
| #include <signal.h> |
| #include <sys/prctl.h> |
| #endif |
| #if defined(OS_LINUX) |
| #include <fontconfig/fontconfig.h> |
| #endif |
| |
| #if defined(OS_ANDROID) |
| #include "chromecast/app/android/crash_handler.h" |
| #include "chromecast/browser/media/cast_media_client_android.h" |
| #include "components/crash/content/browser/crash_dump_manager_android.h" |
| #include "media/base/android/media_client_android.h" |
| #include "media/base/media_switches.h" |
| #include "net/android/network_change_notifier_factory_android.h" |
| #else |
| #include "chromecast/net/network_change_notifier_factory_cast.h" |
| #endif |
| |
| #if defined(USE_AURA) |
| // gn check ignored on OverlayManagerCast as it's not a public ozone |
| // header, but is exported to allow injecting the overlay-composited |
| // callback. |
| #include "chromecast/graphics/cast_screen.h" |
| #include "ui/display/screen.h" |
| #include "ui/ozone/platform/cast/overlay_manager_cast.h" // nogncheck |
| #endif |
| |
| namespace { |
| |
| #if !defined(OS_ANDROID) |
| int kSignalsToRunClosure[] = { SIGTERM, SIGINT, }; |
| // Closure to run on SIGTERM and SIGINT. |
| base::Closure* g_signal_closure = nullptr; |
| base::PlatformThreadId g_main_thread_id; |
| |
| void RunClosureOnSignal(int signum) { |
| if (base::PlatformThread::CurrentId() != g_main_thread_id) { |
| RAW_LOG(INFO, "Received signal on non-main thread\n"); |
| return; |
| } |
| |
| char message[48] = "Received close signal: "; |
| strncat(message, sys_siglist[signum], sizeof(message) - strlen(message) - 1); |
| RAW_LOG(INFO, message); |
| |
| DCHECK(g_signal_closure); |
| g_signal_closure->Run(); |
| } |
| |
| void RegisterClosureOnSignal(const base::Closure& closure) { |
| DCHECK(!g_signal_closure); |
| DCHECK_GT(arraysize(kSignalsToRunClosure), 0U); |
| |
| // Memory leak on purpose, since |g_signal_closure| should live until |
| // process exit. |
| g_signal_closure = new base::Closure(closure); |
| g_main_thread_id = base::PlatformThread::CurrentId(); |
| |
| struct sigaction sa_new; |
| memset(&sa_new, 0, sizeof(sa_new)); |
| sa_new.sa_handler = RunClosureOnSignal; |
| sigfillset(&sa_new.sa_mask); |
| sa_new.sa_flags = SA_RESTART; |
| |
| for (int sig : kSignalsToRunClosure) { |
| struct sigaction sa_old; |
| if (sigaction(sig, &sa_new, &sa_old) == -1) { |
| NOTREACHED(); |
| } else { |
| DCHECK_EQ(sa_old.sa_handler, SIG_DFL); |
| } |
| } |
| |
| // Get the first signal to exit when the parent process dies. |
| prctl(PR_SET_PDEATHSIG, kSignalsToRunClosure[0]); |
| } |
| |
| const int kKillOnAlarmTimeoutSec = 5; // 5 seconds |
| |
| void KillOnAlarm(int signum) { |
| LOG(ERROR) << "Got alarm signal for termination: " << signum; |
| raise(SIGKILL); |
| } |
| |
| void RegisterKillOnAlarm(int timeout_seconds) { |
| struct sigaction sa_new; |
| memset(&sa_new, 0, sizeof(sa_new)); |
| sa_new.sa_handler = KillOnAlarm; |
| sigfillset(&sa_new.sa_mask); |
| sa_new.sa_flags = SA_RESTART; |
| |
| struct sigaction sa_old; |
| if (sigaction(SIGALRM, &sa_new, &sa_old) == -1) { |
| NOTREACHED(); |
| } else { |
| DCHECK_EQ(sa_old.sa_handler, SIG_DFL); |
| } |
| |
| if (alarm(timeout_seconds) > 0) |
| NOTREACHED() << "Previous alarm() was cancelled"; |
| } |
| |
| void DeregisterKillOnAlarm() { |
| // Explicitly cancel any outstanding alarm() calls. |
| alarm(0); |
| |
| struct sigaction sa_new; |
| memset(&sa_new, 0, sizeof(sa_new)); |
| sa_new.sa_handler = SIG_DFL; |
| sigfillset(&sa_new.sa_mask); |
| sa_new.sa_flags = SA_RESTART; |
| |
| struct sigaction sa_old; |
| if (sigaction(SIGALRM, &sa_new, &sa_old) == -1) { |
| NOTREACHED(); |
| } else { |
| DCHECK_EQ(sa_old.sa_handler, KillOnAlarm); |
| } |
| } |
| |
| #endif // !defined(OS_ANDROID) |
| |
| } // namespace |
| |
| namespace chromecast { |
| namespace shell { |
| |
| namespace { |
| |
| struct DefaultCommandLineSwitch { |
| const char* const switch_name; |
| const char* const switch_value; |
| }; |
| |
| DefaultCommandLineSwitch g_default_switches[] = { |
| #if defined(OS_ANDROID) |
| // Disables Chromecast-specific WiFi-related features on ATV for now. |
| { switches::kNoWifi, "" }, |
| { switches::kDisableGestureRequirementForMediaPlayback, ""}, |
| // TODO(sanfin): Unified Media Pipeline is disabled on ATV because of extant |
| // issues with DRM and v8 that block media playback for numerous apps. |
| // Reenable when the Unified Media Pipeline is stable enough for testing. |
| { switches::kDisableUnifiedMediaPipeline, ""}, |
| #else |
| // GPU shader disk cache disabling is largely to conserve disk space. |
| { switches::kDisableGpuShaderDiskCache, "" }, |
| #endif |
| // Always enable HTMLMediaElement logs. |
| { switches::kBlinkPlatformLogChannels, "Media"}, |
| #if BUILDFLAG(DISABLE_DISPLAY) |
| { switches::kDisableGpu, "" }, |
| #endif |
| #if defined(OS_LINUX) |
| #if defined(ARCH_CPU_X86_FAMILY) |
| // This is needed for now to enable the x11 Ozone platform to work with |
| // current Linux/NVidia OpenGL drivers. |
| { switches::kIgnoreGpuBlacklist, ""}, |
| #elif defined(ARCH_CPU_ARM_FAMILY) |
| // On Linux arm, enable CMA pipeline by default. |
| { switches::kEnableCmaMediaPipeline, "" }, |
| #if !BUILDFLAG(DISABLE_DISPLAY) |
| { switches::kEnableHardwareOverlays, "" }, |
| #endif |
| #endif |
| #endif // defined(OS_LINUX) |
| // Needed so that our call to GpuDataManager::SetGLStrings doesn't race |
| // against GPU process creation (which is otherwise triggered from |
| // BrowserThreadsStarted). The GPU process will be created as soon as a |
| // renderer needs it, which always happens after main loop starts. |
| { switches::kDisableGpuEarlyInit, "" }, |
| // Enable navigator.connection API. |
| // TODO(derekjchow): Remove this switch when enabled by default. |
| { switches::kEnableNetworkInformation, "" }, |
| { NULL, NULL }, // Termination |
| }; |
| |
| void AddDefaultCommandLineSwitches(base::CommandLine* command_line) { |
| int i = 0; |
| while (g_default_switches[i].switch_name != NULL) { |
| command_line->AppendSwitchASCII( |
| std::string(g_default_switches[i].switch_name), |
| std::string(g_default_switches[i].switch_value)); |
| ++i; |
| } |
| } |
| |
| } // namespace |
| |
| CastBrowserMainParts::CastBrowserMainParts( |
| const content::MainFunctionParams& parameters, |
| URLRequestContextFactory* url_request_context_factory) |
| : BrowserMainParts(), |
| cast_browser_process_(new CastBrowserProcess()), |
| parameters_(parameters), |
| url_request_context_factory_(url_request_context_factory), |
| net_log_(new CastNetLog()) { |
| base::CommandLine* command_line = base::CommandLine::ForCurrentProcess(); |
| AddDefaultCommandLineSwitches(command_line); |
| |
| #if !defined(OS_ANDROID) |
| media_resource_tracker_ = nullptr; |
| #endif // !defined(OS_ANDROID) |
| } |
| |
| CastBrowserMainParts::~CastBrowserMainParts() { |
| } |
| |
| scoped_refptr<base::SingleThreadTaskRunner> |
| CastBrowserMainParts::GetMediaTaskRunner() { |
| #if defined(OS_ANDROID) |
| return nullptr; |
| #else |
| if (!media_thread_) { |
| media_thread_.reset(new base::Thread("CastMediaThread")); |
| CHECK(media_thread_->Start()); |
| } |
| return media_thread_->task_runner(); |
| #endif |
| } |
| |
| #if !defined(OS_ANDROID) |
| media::MediaResourceTracker* CastBrowserMainParts::media_resource_tracker() { |
| if (!media_resource_tracker_) { |
| media_resource_tracker_ = new media::MediaResourceTracker( |
| base::ThreadTaskRunnerHandle::Get(), GetMediaTaskRunner()); |
| } |
| return media_resource_tracker_; |
| } |
| |
| media::MediaPipelineBackendManager* |
| CastBrowserMainParts::media_pipeline_backend_manager() { |
| if (!media_pipeline_backend_manager_) { |
| media_pipeline_backend_manager_.reset( |
| new media::MediaPipelineBackendManager(GetMediaTaskRunner())); |
| } |
| return media_pipeline_backend_manager_.get(); |
| } |
| #endif |
| |
| void CastBrowserMainParts::PreMainMessageLoopStart() { |
| // GroupedHistograms needs to be initialized before any threads are created |
| // to prevent race conditions between calls to Preregister and those threads |
| // attempting to collect metrics. |
| // This call must also be before NetworkChangeNotifier, as it generates |
| // Net/DNS metrics. |
| metrics::PreregisterAllGroupedHistograms(); |
| |
| #if defined(OS_ANDROID) |
| net::NetworkChangeNotifier::SetFactory( |
| new net::NetworkChangeNotifierFactoryAndroid()); |
| #else |
| net::NetworkChangeNotifier::SetFactory( |
| new NetworkChangeNotifierFactoryCast()); |
| #endif // defined(OS_ANDROID) |
| } |
| |
| void CastBrowserMainParts::PostMainMessageLoopStart() { |
| cast_browser_process_->SetMetricsHelper(base::WrapUnique( |
| new metrics::CastMetricsHelper(base::ThreadTaskRunnerHandle::Get()))); |
| |
| #if defined(OS_ANDROID) |
| base::MessageLoopForUI::current()->Start(); |
| #endif // defined(OS_ANDROID) |
| } |
| |
| void CastBrowserMainParts::ToolkitInitialized() { |
| #if defined(OS_LINUX) |
| // Without this call, the FontConfig library gets implicitly initialized |
| // on the first call to FontConfig. Since it's not safe to initialize it |
| // concurrently from multiple threads, we explicitly initialize it here |
| // to prevent races when there are multiple renderer's querying the library: |
| // http://crbug.com/404311 |
| // Also, implicit initialization can cause a long delay on the first |
| // rendering if the font cache has to be regenerated for some reason. Doing it |
| // explicitly here helps in cases where the browser process is starting up in |
| // the background (resources have not yet been granted to cast) since it |
| // prevents the long delay the user would have seen on first rendering. Note |
| // that future calls to FcInit() are safe no-ops per the FontConfig interface. |
| FcInit(); |
| #endif |
| } |
| |
| int CastBrowserMainParts::PreCreateThreads() { |
| #if defined(OS_ANDROID) |
| // GPU process is started immediately after threads are created, requiring |
| // CrashDumpManager to be initialized beforehand. |
| base::FilePath crash_dumps_dir; |
| if (!chromecast::CrashHandler::GetCrashDumpLocation(&crash_dumps_dir)) { |
| LOG(ERROR) << "Could not find crash dump location."; |
| } |
| cast_browser_process_->SetCrashDumpManager( |
| base::WrapUnique(new breakpad::CrashDumpManager(crash_dumps_dir))); |
| #else |
| base::FilePath home_dir; |
| CHECK(PathService::Get(DIR_CAST_HOME, &home_dir)); |
| if (!base::CreateDirectory(home_dir)) |
| return 1; |
| |
| // Hook for internal code |
| cast_browser_process_->browser_client()->PreCreateThreads(); |
| |
| // Set GL strings so GPU config code can make correct feature blacklisting/ |
| // whitelisting decisions. |
| // Note: SetGLStrings can be called before GpuDataManager::Initialize. |
| std::unique_ptr<CastSysInfo> sys_info = CreateSysInfo(); |
| content::GpuDataManager::GetInstance()->SetGLStrings( |
| sys_info->GetGlVendor(), sys_info->GetGlRenderer(), |
| sys_info->GetGlVersion()); |
| #endif |
| |
| #if defined(USE_AURA) |
| // Screen can (and should) exist even with no displays connected. Its presence |
| // is assumed as an interface to access display information, e.g. from metrics |
| // code. See CastContentWindow::CreateWindowTree for update when resolution |
| // is available. |
| cast_browser_process_->SetCastScreen(base::WrapUnique(new CastScreen)); |
| DCHECK(!display::Screen::GetScreen()); |
| display::Screen::SetScreenInstance(cast_browser_process_->cast_screen()); |
| #endif |
| |
| content::ChildProcessSecurityPolicy::GetInstance()->RegisterWebSafeScheme( |
| kChromeResourceScheme); |
| return 0; |
| } |
| |
| void CastBrowserMainParts::PreMainMessageLoopRun() { |
| scoped_refptr<PrefRegistrySimple> pref_registry(new PrefRegistrySimple()); |
| metrics::RegisterPrefs(pref_registry.get()); |
| cast_browser_process_->SetPrefService( |
| PrefServiceHelper::CreatePrefService(pref_registry.get())); |
| |
| #if defined(OS_ANDROID) |
| ::media::SetMediaClientAndroid(new media::CastMediaClientAndroid()); |
| #else |
| memory_pressure_monitor_.reset(new CastMemoryPressureMonitor()); |
| #endif // defined(OS_ANDROID) |
| |
| cast_browser_process_->SetConnectivityChecker( |
| ConnectivityChecker::Create( |
| content::BrowserThread::GetMessageLoopProxyForThread( |
| content::BrowserThread::IO))); |
| |
| cast_browser_process_->SetNetLog(net_log_.get()); |
| |
| url_request_context_factory_->InitializeOnUIThread(net_log_.get()); |
| |
| cast_browser_process_->SetBrowserContext( |
| base::WrapUnique(new CastBrowserContext(url_request_context_factory_))); |
| cast_browser_process_->SetMetricsServiceClient( |
| metrics::CastMetricsServiceClient::Create( |
| content::BrowserThread::GetBlockingPool(), |
| cast_browser_process_->pref_service(), |
| content::BrowserContext::GetDefaultStoragePartition( |
| cast_browser_process_->browser_context())-> |
| GetURLRequestContext())); |
| |
| if (!PlatformClientAuth::Initialize()) |
| LOG(ERROR) << "PlatformClientAuth::Initialize failed."; |
| |
| cast_browser_process_->SetRemoteDebuggingServer(base::WrapUnique( |
| new RemoteDebuggingServer(cast_browser_process_->browser_client() |
| ->EnableRemoteDebuggingImmediately()))); |
| |
| #if defined(USE_AURA) && !BUILDFLAG(DISABLE_DISPLAY) |
| // TODO(halliwell) move audio builds to use ozone_platform_cast, then can |
| // simplify this by removing DISABLE_DISPLAY condition. Should then also |
| // assert(ozone_platform_cast) in BUILD.gn where it depends on //ui/ozone. |
| video_plane_controller_.reset( |
| new media::VideoPlaneController(GetMediaTaskRunner())); |
| cast_browser_process_->cast_screen()->SetDisplayResizeCallback( |
| base::Bind(&media::VideoPlaneController::SetGraphicsPlaneResolution, |
| base::Unretained(video_plane_controller_.get()))); |
| ui::OverlayManagerCast::SetOverlayCompositedCallback( |
| base::Bind(&media::VideoPlaneController::SetGeometry, |
| base::Unretained(video_plane_controller_.get()))); |
| #endif |
| |
| cast_browser_process_->SetCastService( |
| cast_browser_process_->browser_client()->CreateCastService( |
| cast_browser_process_->browser_context(), |
| cast_browser_process_->pref_service(), |
| url_request_context_factory_->GetSystemGetter(), |
| video_plane_controller_.get())); |
| cast_browser_process_->cast_service()->Initialize(); |
| |
| #if !defined(OS_ANDROID) |
| media_resource_tracker()->InitializeMediaLib(); |
| #endif |
| ::media::InitializeMediaLibrary(); |
| |
| // Initializing metrics service and network delegates must happen after cast |
| // service is intialized because CastMetricsServiceClient and |
| // CastNetworkDelegate may use components initialized by cast service. |
| cast_browser_process_->metrics_service_client() |
| ->Initialize(cast_browser_process_->cast_service()); |
| url_request_context_factory_->InitializeNetworkDelegates(); |
| |
| cast_browser_process_->cast_service()->Start(); |
| } |
| |
| bool CastBrowserMainParts::MainMessageLoopRun(int* result_code) { |
| #if defined(OS_ANDROID) |
| // Android does not use native main MessageLoop. |
| NOTREACHED(); |
| return true; |
| #else |
| base::RunLoop run_loop; |
| base::Closure quit_closure(run_loop.QuitClosure()); |
| RegisterClosureOnSignal(quit_closure); |
| |
| // If parameters_.ui_task is not NULL, we are running browser tests. |
| if (parameters_.ui_task) { |
| base::MessageLoop* message_loop = base::MessageLoopForUI::current(); |
| message_loop->PostTask(FROM_HERE, *parameters_.ui_task); |
| message_loop->PostTask(FROM_HERE, quit_closure); |
| } |
| |
| run_loop.Run(); |
| |
| // Once the main loop has stopped running, we give the browser process a few |
| // seconds to stop cast service and finalize all resources. If a hang occurs |
| // and cast services refuse to terminate successfully, then we SIGKILL the |
| // current process to avoid indefinte hangs. |
| RegisterKillOnAlarm(kKillOnAlarmTimeoutSec); |
| |
| cast_browser_process_->cast_service()->Stop(); |
| return true; |
| #endif |
| } |
| |
| void CastBrowserMainParts::PostMainMessageLoopRun() { |
| #if defined(OS_ANDROID) |
| // Android does not use native main MessageLoop. |
| NOTREACHED(); |
| #else |
| cast_browser_process_->cast_service()->Finalize(); |
| cast_browser_process_->metrics_service_client()->Finalize(); |
| cast_browser_process_.reset(); |
| |
| DeregisterKillOnAlarm(); |
| #endif |
| } |
| |
| void CastBrowserMainParts::PostDestroyThreads() { |
| #if !defined(OS_ANDROID) |
| media_resource_tracker_->FinalizeAndDestroy(); |
| media_resource_tracker_ = nullptr; |
| media_pipeline_backend_manager_.reset(); |
| #endif |
| } |
| |
| } // namespace shell |
| } // namespace chromecast |