| // Copyright (c) 2012 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. |
| |
| #ifndef CONTENT_BROWSER_GPU_BROWSER_GPU_CHANNEL_HOST_FACTORY_H_ |
| #define CONTENT_BROWSER_GPU_BROWSER_GPU_CHANNEL_HOST_FACTORY_H_ |
| |
| #include <vector> |
| |
| #include "base/memory/ref_counted.h" |
| #include "base/memory/scoped_ptr.h" |
| #include "base/process/process.h" |
| #include "base/synchronization/waitable_event.h" |
| #include "content/common/gpu/client/gpu_channel_host.h" |
| #include "ipc/ipc_channel_handle.h" |
| |
| namespace content { |
| |
| class CONTENT_EXPORT BrowserGpuChannelHostFactory |
| : public GpuChannelHostFactory { |
| public: |
| static void Initialize(bool establish_gpu_channel); |
| static void Terminate(); |
| static BrowserGpuChannelHostFactory* instance() { return instance_; } |
| |
| // GpuChannelHostFactory implementation. |
| virtual bool IsMainThread() OVERRIDE; |
| virtual base::MessageLoop* GetMainLoop() OVERRIDE; |
| virtual scoped_refptr<base::MessageLoopProxy> GetIOLoopProxy() OVERRIDE; |
| virtual base::WaitableEvent* GetShutDownEvent() OVERRIDE; |
| virtual scoped_ptr<base::SharedMemory> AllocateSharedMemory( |
| size_t size) OVERRIDE; |
| virtual int32 CreateViewCommandBuffer( |
| int32 surface_id, |
| const GPUCreateCommandBufferConfig& init_params) OVERRIDE; |
| virtual void CreateImage( |
| gfx::PluginWindowHandle window, |
| int32 image_id, |
| const CreateImageCallback& callback) OVERRIDE; |
| virtual void DeleteImage(int32 image_idu, int32 sync_point) OVERRIDE; |
| virtual scoped_ptr<gfx::GpuMemoryBuffer> AllocateGpuMemoryBuffer( |
| size_t width, |
| size_t height, |
| unsigned internalformat) OVERRIDE; |
| |
| // Specify a task runner and callback to be used for a set of messages. The |
| // callback will be set up on the current GpuProcessHost, identified by |
| // GpuProcessHostId(). |
| virtual void SetHandlerForControlMessages( |
| const uint32* message_ids, |
| size_t num_messages, |
| const base::Callback<void(const IPC::Message&)>& handler, |
| base::TaskRunner* target_task_runner); |
| int GpuProcessHostId() { return gpu_host_id_; } |
| GpuChannelHost* EstablishGpuChannelSync( |
| CauseForGpuLaunch cause_for_gpu_launch); |
| void EstablishGpuChannel(CauseForGpuLaunch cause_for_gpu_launch, |
| const base::Closure& callback); |
| GpuChannelHost* GetGpuChannel(); |
| int GetGpuChannelId() { return gpu_client_id_; } |
| |
| // Used to skip GpuChannelHost tests when there can be no GPU process. |
| static bool CanUseForTesting(); |
| |
| private: |
| struct CreateRequest { |
| CreateRequest(); |
| ~CreateRequest(); |
| base::WaitableEvent event; |
| int gpu_host_id; |
| int32 route_id; |
| }; |
| |
| class EstablishRequest : public base::RefCountedThreadSafe<EstablishRequest> { |
| public: |
| explicit EstablishRequest(CauseForGpuLaunch cause, |
| int gpu_client_id, |
| int gpu_host_id); |
| void Wait(); |
| void Cancel(); |
| |
| int gpu_host_id() { return gpu_host_id_; } |
| IPC::ChannelHandle& channel_handle() { return channel_handle_; } |
| gpu::GPUInfo gpu_info() { return gpu_info_; } |
| |
| private: |
| friend class base::RefCountedThreadSafe<EstablishRequest>; |
| ~EstablishRequest(); |
| void EstablishOnIO(); |
| void OnEstablishedOnIO(const IPC::ChannelHandle& channel_handle, |
| const gpu::GPUInfo& gpu_info); |
| void FinishOnIO(); |
| void FinishOnMain(); |
| |
| base::WaitableEvent event_; |
| CauseForGpuLaunch cause_for_gpu_launch_; |
| const int gpu_client_id_; |
| int gpu_host_id_; |
| bool reused_gpu_process_; |
| IPC::ChannelHandle channel_handle_; |
| gpu::GPUInfo gpu_info_; |
| bool finished_; |
| scoped_refptr<base::MessageLoopProxy> main_loop_; |
| }; |
| |
| explicit BrowserGpuChannelHostFactory(bool establish_gpu_channel); |
| virtual ~BrowserGpuChannelHostFactory(); |
| |
| void GpuChannelEstablished(); |
| void CreateViewCommandBufferOnIO( |
| CreateRequest* request, |
| int32 surface_id, |
| const GPUCreateCommandBufferConfig& init_params); |
| static void CommandBufferCreatedOnIO(CreateRequest* request, int32 route_id); |
| void CreateImageOnIO( |
| gfx::PluginWindowHandle window, |
| int32 image_id, |
| const CreateImageCallback& callback); |
| static void ImageCreatedOnIO( |
| const CreateImageCallback& callback, const gfx::Size size); |
| static void OnImageCreated( |
| const CreateImageCallback& callback, const gfx::Size size); |
| void DeleteImageOnIO(int32 image_id, int32 sync_point); |
| static void AddFilterOnIO( |
| int gpu_host_id, |
| scoped_refptr<IPC::ChannelProxy::MessageFilter> filter); |
| |
| const int gpu_client_id_; |
| scoped_ptr<base::WaitableEvent> shutdown_event_; |
| scoped_refptr<GpuChannelHost> gpu_channel_; |
| int gpu_host_id_; |
| scoped_refptr<EstablishRequest> pending_request_; |
| std::vector<base::Closure> established_callbacks_; |
| |
| static BrowserGpuChannelHostFactory* instance_; |
| |
| DISALLOW_COPY_AND_ASSIGN(BrowserGpuChannelHostFactory); |
| }; |
| |
| } // namespace content |
| |
| #endif // CONTENT_BROWSER_GPU_BROWSER_GPU_CHANNEL_HOST_FACTORY_H_ |