Index: content/browser/gpu/gpu_arc_video_service_host.cc |
diff --git a/content/browser/gpu/gpu_arc_video_service_host.cc b/content/browser/gpu/gpu_arc_video_service_host.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..5c512b3f0d21206342d1956e36907d3fac30fdf4 |
--- /dev/null |
+++ b/content/browser/gpu/gpu_arc_video_service_host.cc |
@@ -0,0 +1,96 @@ |
+// Copyright 2015 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 "content/browser/gpu/gpu_arc_video_service_host.h" |
+ |
+#include "base/location.h" |
+#include "base/logging.h" |
+#include "base/message_loop/message_loop.h" |
+#include "content/browser/gpu/gpu_process_host.h" |
+#include "content/common/gpu/gpu_messages.h" |
+#include "ipc/ipc_message_macros.h" |
+#include "ipc/ipc_message_utils.h" |
+ |
+namespace content { |
+ |
+namespace { |
+void CreateChannelOnIOThread( |
+ const GpuProcessHost::CreateArcVideoAcceleratorChannelCallback& callback) { |
+ GpuProcessHost* gpu_process_host = |
+ GpuProcessHost::Get(GpuProcessHost::GPU_PROCESS_KIND_SANDBOXED, |
+ CAUSE_FOR_GPU_LAUNCH_ARCVIDEOACCELERATOR); |
+ gpu_process_host->CreateArcVideoAcceleratorChannel(callback); |
+} |
+} |
+ |
+GpuArcVideoServiceHost::GpuArcVideoServiceHost( |
+ const scoped_refptr<base::SingleThreadTaskRunner>& io_task_runner) |
+ : io_task_runner_(io_task_runner), |
+ num_pending_request_(0), |
+ weak_factory_(this) {} |
+ |
+GpuArcVideoServiceHost::~GpuArcVideoServiceHost() { |
+ DCHECK(CalledOnValidThread()); |
+ |
+ arc::ArcBridgeService* bridge_service = arc::ArcBridgeService::Get(); |
+ if (bridge_service) { |
+ while (num_pending_request_ > 0) |
+ NotifyArcAcceleratorChannelCreated(IPC::ChannelHandle()); |
+ bridge_service->RemoveObserver(this); |
+ bridge_service->RemoveVideoServiceObserver(this); |
+ } |
+} |
+ |
+void GpuArcVideoServiceHost::Initialize() { |
+ DCHECK(CalledOnValidThread()); |
+ |
+ arc::ArcBridgeService* bridge_service = arc::ArcBridgeService::Get(); |
+ DCHECK(bridge_service); |
Pawel Osciak
2015/12/16 10:17:58
Should we actually if(bridge_service) here (and in
kcwu
2015/12/16 14:05:33
Basically it is bug if bridge_service is null, hen
|
+ bridge_service->AddObserver(this); |
+ bridge_service->AddVideoServiceObserver(this); |
+} |
+ |
+void GpuArcVideoServiceHost::OnStateChanged( |
+ arc::ArcBridgeService::State state) { |
+ DCHECK(CalledOnValidThread()); |
+ switch (state) { |
+ case arc::ArcBridgeService::State::STOPPING: |
+ Shutdown(); |
+ break; |
+ default: |
+ break; |
+ } |
+} |
+ |
+void GpuArcVideoServiceHost::OnRequestArcVideoAcceleratorChannel() { |
+ DCHECK(CalledOnValidThread()); |
+ num_pending_request_++; |
+ io_task_runner_->PostTask( |
+ FROM_HERE, |
+ base::Bind( |
+ &CreateChannelOnIOThread, |
+ base::Bind( |
+ &GpuArcVideoServiceHost::NotifyArcAcceleratorChannelCreated, |
+ weak_factory_.GetWeakPtr()))); |
+} |
+ |
+void GpuArcVideoServiceHost::Shutdown() { |
+ GpuProcessHost::SendOnIO(GpuProcessHost::GPU_PROCESS_KIND_SANDBOXED, |
+ CAUSE_FOR_GPU_LAUNCH_NO_LAUNCH, |
+ new GpuMsg_ShutdownArcVideoService()); |
+} |
+ |
+void GpuArcVideoServiceHost::NotifyArcAcceleratorChannelCreated( |
+ const IPC::ChannelHandle& handle) { |
+ DCHECK(CalledOnValidThread()); |
+ |
+ DCHECK_GT(num_pending_request_, 0); |
+ |
+ arc::ArcBridgeService* bridge_service = arc::ArcBridgeService::Get(); |
+ DCHECK(bridge_service); |
+ num_pending_request_--; |
+ ignore_result(bridge_service->NotifyVideoAcceleratorChannelCreated(handle)); |
Pawel Osciak
2015/12/16 10:17:58
Is there any other caller that doesn't ignore_resu
kcwu
2015/12/16 14:05:33
Done.
|
+} |
+ |
+} // namespace content |