| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "content/gpu/gpu_child_thread.h" | 5 #include "content/gpu/gpu_child_thread.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/lazy_instance.h" | 8 #include "base/lazy_instance.h" |
| 9 #include "base/threading/worker_pool.h" | 9 #include "base/threading/worker_pool.h" |
| 10 #include "build/build_config.h" | 10 #include "build/build_config.h" |
| 11 #include "content/child/child_process.h" | 11 #include "content/child/child_process.h" |
| 12 #include "content/child/thread_safe_sender.h" | 12 #include "content/child/thread_safe_sender.h" |
| 13 #include "content/common/gpu/gpu_messages.h" | 13 #include "content/common/gpu/gpu_messages.h" |
| 14 #include "content/gpu/gpu_watchdog_thread.h" | 14 #include "content/gpu/gpu_watchdog_thread.h" |
| 15 #include "content/public/common/content_client.h" | 15 #include "content/public/common/content_client.h" |
| 16 #include "content/public/common/content_switches.h" | 16 #include "content/public/common/content_switches.h" |
| 17 #include "gpu/config/gpu_info_collector.h" | 17 #include "gpu/config/gpu_info_collector.h" |
| 18 #include "ipc/ipc_channel_handle.h" | 18 #include "ipc/ipc_channel_handle.h" |
| 19 #include "ipc/ipc_sync_message_filter.h" | 19 #include "ipc/ipc_sync_message_filter.h" |
| 20 #include "ui/gl/gl_implementation.h" | 20 #include "ui/gl/gl_implementation.h" |
| 21 | 21 |
| 22 #if defined(USE_OZONE) |
| 23 #include "ui/ozone/gpu/gpu_platform_support.h" |
| 24 #endif |
| 25 |
| 22 namespace content { | 26 namespace content { |
| 23 namespace { | 27 namespace { |
| 24 | 28 |
| 25 static base::LazyInstance<scoped_refptr<ThreadSafeSender> > | 29 static base::LazyInstance<scoped_refptr<ThreadSafeSender> > |
| 26 g_thread_safe_sender = LAZY_INSTANCE_INITIALIZER; | 30 g_thread_safe_sender = LAZY_INSTANCE_INITIALIZER; |
| 27 | 31 |
| 28 bool GpuProcessLogMessageHandler(int severity, | 32 bool GpuProcessLogMessageHandler(int severity, |
| 29 const char* file, int line, | 33 const char* file, int line, |
| 30 size_t message_start, | 34 size_t message_start, |
| 31 const std::string& str) { | 35 const std::string& str) { |
| (...skipping 74 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 106 IPC_MESSAGE_HANDLER(GpuMsg_Clean, OnClean) | 110 IPC_MESSAGE_HANDLER(GpuMsg_Clean, OnClean) |
| 107 IPC_MESSAGE_HANDLER(GpuMsg_Crash, OnCrash) | 111 IPC_MESSAGE_HANDLER(GpuMsg_Crash, OnCrash) |
| 108 IPC_MESSAGE_HANDLER(GpuMsg_Hang, OnHang) | 112 IPC_MESSAGE_HANDLER(GpuMsg_Hang, OnHang) |
| 109 IPC_MESSAGE_HANDLER(GpuMsg_DisableWatchdog, OnDisableWatchdog) | 113 IPC_MESSAGE_HANDLER(GpuMsg_DisableWatchdog, OnDisableWatchdog) |
| 110 IPC_MESSAGE_UNHANDLED(handled = false) | 114 IPC_MESSAGE_UNHANDLED(handled = false) |
| 111 IPC_END_MESSAGE_MAP() | 115 IPC_END_MESSAGE_MAP() |
| 112 | 116 |
| 113 if (handled) | 117 if (handled) |
| 114 return true; | 118 return true; |
| 115 | 119 |
| 120 #if defined(USE_OZONE) |
| 121 if (ui::GpuPlatformSupport::GetInstance()->OnMessageReceived(msg)) |
| 122 return true; |
| 123 #endif |
| 124 |
| 116 return gpu_channel_manager_.get() && | 125 return gpu_channel_manager_.get() && |
| 117 gpu_channel_manager_->OnMessageReceived(msg); | 126 gpu_channel_manager_->OnMessageReceived(msg); |
| 118 } | 127 } |
| 119 | 128 |
| 120 void GpuChildThread::OnInitialize() { | 129 void GpuChildThread::OnInitialize() { |
| 121 // Record initialization only after collecting the GPU info because that can | 130 // Record initialization only after collecting the GPU info because that can |
| 122 // take a significant amount of time. | 131 // take a significant amount of time. |
| 123 gpu_info_.initialization_time = base::Time::Now() - process_start_time_; | 132 gpu_info_.initialization_time = base::Time::Now() - process_start_time_; |
| 124 Send(new GpuHostMsg_Initialized(!dead_on_arrival_, gpu_info_)); | 133 Send(new GpuHostMsg_Initialized(!dead_on_arrival_, gpu_info_)); |
| 125 while (!deferred_messages_.empty()) { | 134 while (!deferred_messages_.empty()) { |
| (...skipping 19 matching lines...) Expand all Loading... |
| 145 logging::SetLogMessageHandler(GpuProcessLogMessageHandler); | 154 logging::SetLogMessageHandler(GpuProcessLogMessageHandler); |
| 146 | 155 |
| 147 // Defer creation of the render thread. This is to prevent it from handling | 156 // Defer creation of the render thread. This is to prevent it from handling |
| 148 // IPC messages before the sandbox has been enabled and all other necessary | 157 // IPC messages before the sandbox has been enabled and all other necessary |
| 149 // initialization has succeeded. | 158 // initialization has succeeded. |
| 150 gpu_channel_manager_.reset( | 159 gpu_channel_manager_.reset( |
| 151 new GpuChannelManager(GetRouter(), | 160 new GpuChannelManager(GetRouter(), |
| 152 watchdog_thread_.get(), | 161 watchdog_thread_.get(), |
| 153 ChildProcess::current()->io_message_loop_proxy(), | 162 ChildProcess::current()->io_message_loop_proxy(), |
| 154 ChildProcess::current()->GetShutDownEvent())); | 163 ChildProcess::current()->GetShutDownEvent())); |
| 164 |
| 165 #if defined(USE_OZONE) |
| 166 ui::GpuPlatformSupport::GetInstance()->OnChannelEstablished(this); |
| 167 #endif |
| 155 } | 168 } |
| 156 | 169 |
| 157 void GpuChildThread::StopWatchdog() { | 170 void GpuChildThread::StopWatchdog() { |
| 158 if (watchdog_thread_.get()) { | 171 if (watchdog_thread_.get()) { |
| 159 watchdog_thread_->Stop(); | 172 watchdog_thread_->Stop(); |
| 160 } | 173 } |
| 161 } | 174 } |
| 162 | 175 |
| 163 void GpuChildThread::OnCollectGraphicsInfo() { | 176 void GpuChildThread::OnCollectGraphicsInfo() { |
| 164 #if defined(OS_WIN) | 177 #if defined(OS_WIN) |
| (...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 238 // the future posting of tasks to the message loop. | 251 // the future posting of tasks to the message loop. |
| 239 if (watchdog_thread_->message_loop()) | 252 if (watchdog_thread_->message_loop()) |
| 240 watchdog_thread_->PostAcknowledge(); | 253 watchdog_thread_->PostAcknowledge(); |
| 241 // Prevent rearming. | 254 // Prevent rearming. |
| 242 watchdog_thread_->Stop(); | 255 watchdog_thread_->Stop(); |
| 243 } | 256 } |
| 244 } | 257 } |
| 245 | 258 |
| 246 } // namespace content | 259 } // namespace content |
| 247 | 260 |
| OLD | NEW |