Index: content/common/gpu/client/gpu_channel_host.h |
diff --git a/content/common/gpu/client/gpu_channel_host.h b/content/common/gpu/client/gpu_channel_host.h |
deleted file mode 100644 |
index ab879de36987d35582842dc47753f1531f75f93a..0000000000000000000000000000000000000000 |
--- a/content/common/gpu/client/gpu_channel_host.h |
+++ /dev/null |
@@ -1,299 +0,0 @@ |
-// 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_COMMON_GPU_CLIENT_GPU_CHANNEL_HOST_H_ |
-#define CONTENT_COMMON_GPU_CLIENT_GPU_CHANNEL_HOST_H_ |
- |
-#include <stddef.h> |
-#include <stdint.h> |
- |
-#include <string> |
-#include <vector> |
- |
-#include "base/atomic_sequence_num.h" |
-#include "base/containers/scoped_ptr_hash_map.h" |
-#include "base/macros.h" |
-#include "base/memory/ref_counted.h" |
-#include "base/memory/scoped_ptr.h" |
-#include "base/memory/weak_ptr.h" |
-#include "base/process/process.h" |
-#include "base/synchronization/lock.h" |
-#include "content/common/content_export.h" |
-#include "gpu/config/gpu_info.h" |
-#include "gpu/ipc/common/gpu_stream_constants.h" |
-#include "gpu/ipc/common/surface_handle.h" |
-#include "ipc/ipc_channel_handle.h" |
-#include "ipc/ipc_sync_channel.h" |
-#include "ipc/message_filter.h" |
-#include "ipc/message_router.h" |
-#include "ui/events/latency_info.h" |
-#include "ui/gfx/geometry/size.h" |
-#include "ui/gfx/gpu_memory_buffer.h" |
-#include "ui/gl/gpu_preference.h" |
- |
-class GURL; |
- |
-namespace base { |
-class WaitableEvent; |
-} |
- |
-namespace IPC { |
-class SyncMessageFilter; |
-} |
- |
-namespace gpu { |
-class GpuMemoryBufferManager; |
-} |
- |
-namespace content { |
-class CommandBufferProxyImpl; |
-class GpuChannelHost; |
- |
-class CONTENT_EXPORT GpuChannelHostFactory { |
- public: |
- virtual ~GpuChannelHostFactory() {} |
- |
- virtual bool IsMainThread() = 0; |
- virtual scoped_refptr<base::SingleThreadTaskRunner> |
- GetIOThreadTaskRunner() = 0; |
- virtual scoped_ptr<base::SharedMemory> AllocateSharedMemory(size_t size) = 0; |
-}; |
- |
-// Encapsulates an IPC channel between the client and one GPU process. |
-// On the GPU process side there's a corresponding GpuChannel. |
-// Every method can be called on any thread with a message loop, except for the |
-// IO thread. |
-class GpuChannelHost : public IPC::Sender, |
- public base::RefCountedThreadSafe<GpuChannelHost> { |
- public: |
- // Must be called on the main thread (as defined by the factory). |
- static scoped_refptr<GpuChannelHost> Create( |
- GpuChannelHostFactory* factory, |
- int channel_id, |
- const gpu::GPUInfo& gpu_info, |
- const IPC::ChannelHandle& channel_handle, |
- base::WaitableEvent* shutdown_event, |
- gpu::GpuMemoryBufferManager* gpu_memory_buffer_manager); |
- |
- static const int32_t kDefaultStreamId = gpu::GPU_STREAM_DEFAULT; |
- static const gpu::GpuStreamPriority kDefaultStreamPriority = |
- gpu::GpuStreamPriority::NORMAL; |
- |
- bool IsLost() const { |
- DCHECK(channel_filter_.get()); |
- return channel_filter_->IsLost(); |
- } |
- |
- int channel_id() const { return channel_id_; } |
- |
- // The GPU stats reported by the GPU process. |
- const gpu::GPUInfo& gpu_info() const { return gpu_info_; } |
- |
- // IPC::Sender implementation: |
- bool Send(IPC::Message* msg) override; |
- |
- // Set an ordering barrier. AsyncFlushes any pending barriers on other |
- // routes. Combines multiple OrderingBarriers into a single AsyncFlush. |
- // Returns the flush ID for the stream or 0 if put offset was not changed. |
- uint32_t OrderingBarrier(int32_t route_id, |
- int32_t stream_id, |
- int32_t put_offset, |
- uint32_t flush_count, |
- const std::vector<ui::LatencyInfo>& latency_info, |
- bool put_offset_changed, |
- bool do_flush); |
- |
- void FlushPendingStream(int32_t stream_id); |
- |
- // Create and connect to a command buffer in the GPU process. |
- scoped_ptr<CommandBufferProxyImpl> CreateCommandBuffer( |
- gpu::SurfaceHandle surface_handle, |
- const gfx::Size& size, |
- CommandBufferProxyImpl* share_group, |
- int32_t stream_id, |
- gpu::GpuStreamPriority stream_priority, |
- const std::vector<int32_t>& attribs, |
- const GURL& active_url, |
- gfx::GpuPreference gpu_preference); |
- |
- // Destroy a command buffer created by this channel. |
- void DestroyCommandBuffer(CommandBufferProxyImpl* command_buffer); |
- |
- // Destroy this channel. Must be called on the main thread, before |
- // destruction. |
- void DestroyChannel(); |
- |
- // Add a message route for the current message loop. |
- void AddRoute(int route_id, base::WeakPtr<IPC::Listener> listener); |
- |
- // Add a message route to be handled on the provided |task_runner|. |
- void AddRouteWithTaskRunner( |
- int route_id, |
- base::WeakPtr<IPC::Listener> listener, |
- scoped_refptr<base::SingleThreadTaskRunner> task_runner); |
- |
- // Remove the message route associated with |route_id|. |
- void RemoveRoute(int route_id); |
- |
- GpuChannelHostFactory* factory() const { return factory_; } |
- |
- gpu::GpuMemoryBufferManager* gpu_memory_buffer_manager() const { |
- return gpu_memory_buffer_manager_; |
- } |
- |
- // Returns a handle to the shared memory that can be sent via IPC to the |
- // GPU process. The caller is responsible for ensuring it is closed. Returns |
- // an invalid handle on failure. |
- base::SharedMemoryHandle ShareToGpuProcess( |
- base::SharedMemoryHandle source_handle); |
- |
- // Reserve one unused transfer buffer ID. |
- int32_t ReserveTransferBufferId(); |
- |
- // Returns a GPU memory buffer handle to the buffer that can be sent via |
- // IPC to the GPU process. The caller is responsible for ensuring it is |
- // closed. Returns an invalid handle on failure. |
- gfx::GpuMemoryBufferHandle ShareGpuMemoryBufferToGpuProcess( |
- const gfx::GpuMemoryBufferHandle& source_handle, |
- bool* requires_sync_point); |
- |
- // Reserve one unused image ID. |
- int32_t ReserveImageId(); |
- |
- // Generate a route ID guaranteed to be unique for this channel. |
- int32_t GenerateRouteID(); |
- |
- // Generate a stream ID guaranteed to be unique for this channel. |
- int32_t GenerateStreamID(); |
- |
- // Sends a synchronous nop to the server which validate that all previous IPC |
- // messages have been received. Once the synchronous nop has been sent to the |
- // server all previous flushes will all be marked as validated, including |
- // flushes for other streams on the same channel. Once a validation has been |
- // sent, it will return the highest validated flush id for the stream. |
- // If the validation fails (which can only happen upon context lost), the |
- // highest validated flush id will not change. If no flush ID were ever |
- // validated then it will return 0 (Note the lowest valid flush ID is 1). |
- uint32_t ValidateFlushIDReachedServer(int32_t stream_id, bool force_validate); |
- |
- // Returns the highest validated flush ID for a given stream. |
- uint32_t GetHighestValidatedFlushID(int32_t stream_id); |
- |
- private: |
- friend class base::RefCountedThreadSafe<GpuChannelHost>; |
- |
- // A filter used internally to route incoming messages from the IO thread |
- // to the correct message loop. It also maintains some shared state between |
- // all the contexts. |
- class MessageFilter : public IPC::MessageFilter { |
- public: |
- MessageFilter(); |
- |
- // Called on the IO thread. |
- void AddRoute(int32_t route_id, |
- base::WeakPtr<IPC::Listener> listener, |
- scoped_refptr<base::SingleThreadTaskRunner> task_runner); |
- // Called on the IO thread. |
- void RemoveRoute(int32_t route_id); |
- |
- // IPC::MessageFilter implementation |
- // (called on the IO thread): |
- bool OnMessageReceived(const IPC::Message& msg) override; |
- void OnChannelError() override; |
- |
- // The following methods can be called on any thread. |
- |
- // Whether the channel is lost. |
- bool IsLost() const; |
- |
- private: |
- struct ListenerInfo { |
- ListenerInfo(); |
- ListenerInfo(const ListenerInfo& other); |
- ~ListenerInfo(); |
- |
- base::WeakPtr<IPC::Listener> listener; |
- scoped_refptr<base::SingleThreadTaskRunner> task_runner; |
- }; |
- |
- ~MessageFilter() override; |
- |
- // Threading notes: |listeners_| is only accessed on the IO thread. Every |
- // other field is protected by |lock_|. |
- base::hash_map<int32_t, ListenerInfo> listeners_; |
- |
- // Protects all fields below this one. |
- mutable base::Lock lock_; |
- |
- // Whether the channel has been lost. |
- bool lost_; |
- }; |
- |
- struct StreamFlushInfo { |
- StreamFlushInfo(); |
- StreamFlushInfo(const StreamFlushInfo& other); |
- ~StreamFlushInfo(); |
- |
- // These are global per stream. |
- uint32_t next_stream_flush_id; |
- uint32_t flushed_stream_flush_id; |
- uint32_t verified_stream_flush_id; |
- |
- // These are local per context. |
- bool flush_pending; |
- int32_t route_id; |
- int32_t put_offset; |
- uint32_t flush_count; |
- uint32_t flush_id; |
- std::vector<ui::LatencyInfo> latency_info; |
- }; |
- |
- GpuChannelHost(GpuChannelHostFactory* factory, |
- int channel_id, |
- const gpu::GPUInfo& gpu_info, |
- gpu::GpuMemoryBufferManager* gpu_memory_buffer_manager); |
- ~GpuChannelHost() override; |
- void Connect(const IPC::ChannelHandle& channel_handle, |
- base::WaitableEvent* shutdown_event); |
- bool InternalSend(IPC::Message* msg); |
- void InternalFlush(StreamFlushInfo* flush_info); |
- |
- // Threading notes: all fields are constant during the lifetime of |this| |
- // except: |
- // - |next_image_id_|, atomic type |
- // - |next_route_id_|, atomic type |
- // - |next_stream_id_|, atomic type |
- // - |channel_| and |stream_flush_info_|, protected by |context_lock_| |
- GpuChannelHostFactory* const factory_; |
- |
- const int channel_id_; |
- const gpu::GPUInfo gpu_info_; |
- |
- scoped_refptr<MessageFilter> channel_filter_; |
- |
- gpu::GpuMemoryBufferManager* gpu_memory_buffer_manager_; |
- |
- // A filter for sending messages from thread other than the main thread. |
- scoped_refptr<IPC::SyncMessageFilter> sync_filter_; |
- |
- // Image IDs are allocated in sequence. |
- base::AtomicSequenceNumber next_image_id_; |
- |
- // Route IDs are allocated in sequence. |
- base::AtomicSequenceNumber next_route_id_; |
- |
- // Stream IDs are allocated in sequence. |
- base::AtomicSequenceNumber next_stream_id_; |
- |
- // Protects channel_ and stream_flush_info_. |
- mutable base::Lock context_lock_; |
- scoped_ptr<IPC::SyncChannel> channel_; |
- base::hash_map<int32_t, StreamFlushInfo> stream_flush_info_; |
- |
- DISALLOW_COPY_AND_ASSIGN(GpuChannelHost); |
-}; |
- |
-} // namespace content |
- |
-#endif // CONTENT_COMMON_GPU_CLIENT_GPU_CHANNEL_HOST_H_ |