Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(150)

Side by Side Diff: cc/resources/one_copy_raster_worker_pool.h

Issue 683113005: Update from chromium https://crrev.com/302282 (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 6 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « cc/quads/render_pass.cc ('k') | cc/resources/one_copy_raster_worker_pool.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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 #ifndef CC_RESOURCES_ONE_COPY_RASTER_WORKER_POOL_H_ 5 #ifndef CC_RESOURCES_ONE_COPY_RASTER_WORKER_POOL_H_
6 #define CC_RESOURCES_ONE_COPY_RASTER_WORKER_POOL_H_ 6 #define CC_RESOURCES_ONE_COPY_RASTER_WORKER_POOL_H_
7 7
8 #include "base/memory/weak_ptr.h" 8 #include "base/memory/weak_ptr.h"
9 #include "base/synchronization/lock.h" 9 #include "base/synchronization/lock.h"
10 #include "base/values.h" 10 #include "base/values.h"
11 #include "cc/base/scoped_ptr_deque.h" 11 #include "cc/base/scoped_ptr_deque.h"
12 #include "cc/output/context_provider.h" 12 #include "cc/output/context_provider.h"
13 #include "cc/resources/raster_worker_pool.h" 13 #include "cc/resources/raster_worker_pool.h"
14 #include "cc/resources/rasterizer.h" 14 #include "cc/resources/rasterizer.h"
15 #include "cc/resources/resource_provider.h" 15 #include "cc/resources/resource_provider.h"
16 16
17 namespace base { 17 namespace base {
18 namespace debug { 18 namespace debug {
19 class ConvertableToTraceFormat; 19 class ConvertableToTraceFormat;
20 class TracedValue; 20 class TracedValue;
21 } 21 }
22 } 22 }
23 23
24 namespace cc { 24 namespace cc {
25 class ResourcePool; 25 class ResourcePool;
26 class ResourceProvider; 26 class ScopedResource;
27 27
28 typedef int64 CopySequenceNumber; 28 typedef int64 CopySequenceNumber;
29 29
30 class CC_EXPORT OneCopyRasterWorkerPool : public RasterWorkerPool, 30 class CC_EXPORT OneCopyRasterWorkerPool : public RasterWorkerPool,
31 public Rasterizer, 31 public Rasterizer,
32 public RasterizerTaskClient { 32 public RasterizerTaskClient {
33 public: 33 public:
34 ~OneCopyRasterWorkerPool() override; 34 ~OneCopyRasterWorkerPool() override;
35 35
36 static scoped_ptr<RasterWorkerPool> Create( 36 static scoped_ptr<RasterWorkerPool> Create(
(...skipping 10 matching lines...) Expand all
47 void SetClient(RasterizerClient* client) override; 47 void SetClient(RasterizerClient* client) override;
48 void Shutdown() override; 48 void Shutdown() override;
49 void ScheduleTasks(RasterTaskQueue* queue) override; 49 void ScheduleTasks(RasterTaskQueue* queue) override;
50 void CheckForCompletedTasks() override; 50 void CheckForCompletedTasks() override;
51 51
52 // Overridden from RasterizerTaskClient: 52 // Overridden from RasterizerTaskClient:
53 scoped_ptr<RasterBuffer> AcquireBufferForRaster( 53 scoped_ptr<RasterBuffer> AcquireBufferForRaster(
54 const Resource* resource) override; 54 const Resource* resource) override;
55 void ReleaseBufferForRaster(scoped_ptr<RasterBuffer> buffer) override; 55 void ReleaseBufferForRaster(scoped_ptr<RasterBuffer> buffer) override;
56 56
57 // Schedule copy of |src| resource to |dst| resource. Returns a non-zero 57 // Playback raster source and schedule copy of |src| resource to |dst|
58 // sequence number for this copy operation. 58 // resource. Returns a non-zero sequence number for this copy operation.
59 CopySequenceNumber ScheduleCopyOnWorkerThread( 59 CopySequenceNumber PlaybackAndScheduleCopyOnWorkerThread(
60 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock, 60 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock,
61 const Resource* src, 61 scoped_ptr<ScopedResource> src,
62 const Resource* dst); 62 const Resource* dst,
63 const RasterSource* raster_source,
64 const gfx::Rect& rect,
65 float scale,
66 RenderingStatsInstrumentation* stats);
63 67
64 // Issues copy operations until |sequence| has been processed. This will 68 // Issues copy operations until |sequence| has been processed. This will
65 // return immediately if |sequence| has already been processed. 69 // return immediately if |sequence| has already been processed.
66 void AdvanceLastIssuedCopyTo(CopySequenceNumber sequence); 70 void AdvanceLastIssuedCopyTo(CopySequenceNumber sequence);
67 71
68 protected: 72 protected:
69 OneCopyRasterWorkerPool(base::SequencedTaskRunner* task_runner, 73 OneCopyRasterWorkerPool(base::SequencedTaskRunner* task_runner,
70 TaskGraphRunner* task_graph_runner, 74 TaskGraphRunner* task_graph_runner,
71 ContextProvider* context_provider, 75 ContextProvider* context_provider,
72 ResourceProvider* resource_provider, 76 ResourceProvider* resource_provider,
73 ResourcePool* resource_pool); 77 ResourcePool* resource_pool);
74 78
75 private: 79 private:
76 struct CopyOperation { 80 struct CopyOperation {
77 typedef ScopedPtrDeque<CopyOperation> Deque; 81 typedef ScopedPtrDeque<CopyOperation> Deque;
78 82
79 CopyOperation( 83 CopyOperation(
80 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock, 84 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock,
81 ResourceProvider::ResourceId src, 85 scoped_ptr<ScopedResource> src,
82 ResourceProvider::ResourceId dst); 86 const Resource* dst);
83 ~CopyOperation(); 87 ~CopyOperation();
84 88
85 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock; 89 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock;
86 ResourceProvider::ResourceId src; 90 scoped_ptr<ScopedResource> src;
87 ResourceProvider::ResourceId dst; 91 const Resource* dst;
88 }; 92 };
89 93
90 void OnRasterFinished(TaskSet task_set); 94 void OnRasterFinished(TaskSet task_set);
91 void AdvanceLastFlushedCopyTo(CopySequenceNumber sequence); 95 void AdvanceLastFlushedCopyTo(CopySequenceNumber sequence);
92 void IssueCopyOperations(int64 count); 96 void IssueCopyOperations(int64 count);
97 void ScheduleCheckForCompletedCopyOperationsWithLockAcquired(
98 bool wait_if_needed);
99 void CheckForCompletedCopyOperations(bool wait_if_needed);
93 scoped_refptr<base::debug::ConvertableToTraceFormat> StateAsValue() const; 100 scoped_refptr<base::debug::ConvertableToTraceFormat> StateAsValue() const;
94 void StagingStateAsValueInto(base::debug::TracedValue* staging_state) const; 101 void StagingStateAsValueInto(base::debug::TracedValue* staging_state) const;
95 102
96 scoped_refptr<base::SequencedTaskRunner> task_runner_; 103 scoped_refptr<base::SequencedTaskRunner> task_runner_;
97 TaskGraphRunner* task_graph_runner_; 104 TaskGraphRunner* task_graph_runner_;
98 const NamespaceToken namespace_token_; 105 const NamespaceToken namespace_token_;
99 RasterizerClient* client_; 106 RasterizerClient* client_;
100 ContextProvider* context_provider_; 107 ContextProvider* context_provider_;
101 ResourceProvider* resource_provider_; 108 ResourceProvider* resource_provider_;
102 ResourcePool* resource_pool_; 109 ResourcePool* resource_pool_;
103 TaskSetCollection raster_pending_; 110 TaskSetCollection raster_pending_;
104 scoped_refptr<RasterizerTask> raster_finished_tasks_[kNumberOfTaskSets]; 111 scoped_refptr<RasterizerTask> raster_finished_tasks_[kNumberOfTaskSets];
105 CopySequenceNumber last_issued_copy_operation_; 112 CopySequenceNumber last_issued_copy_operation_;
106 CopySequenceNumber last_flushed_copy_operation_; 113 CopySequenceNumber last_flushed_copy_operation_;
107 114
108 // Task graph used when scheduling tasks and vector used to gather 115 // Task graph used when scheduling tasks and vector used to gather
109 // completed tasks. 116 // completed tasks.
110 TaskGraph graph_; 117 TaskGraph graph_;
111 Task::Vector completed_tasks_; 118 Task::Vector completed_tasks_;
112 119
113 base::Lock lock_; 120 base::Lock lock_;
114 // |lock_| must be acquired when accessing the following members. 121 // |lock_| must be acquired when accessing the following members.
122 base::ConditionVariable copy_operation_count_cv_;
123 size_t scheduled_copy_operation_count_;
124 size_t issued_copy_operation_count_;
115 CopyOperation::Deque pending_copy_operations_; 125 CopyOperation::Deque pending_copy_operations_;
116 CopySequenceNumber next_copy_operation_sequence_; 126 CopySequenceNumber next_copy_operation_sequence_;
127 bool check_for_completed_copy_operations_pending_;
128 base::TimeTicks last_check_for_completed_copy_operations_time_;
129 bool shutdown_;
117 130
118 base::WeakPtrFactory<OneCopyRasterWorkerPool> weak_ptr_factory_; 131 base::WeakPtrFactory<OneCopyRasterWorkerPool> weak_ptr_factory_;
119 // "raster finished" tasks need their own factory as they need to be 132 // "raster finished" tasks need their own factory as they need to be
120 // canceled when ScheduleTasks() is called. 133 // canceled when ScheduleTasks() is called.
121 base::WeakPtrFactory<OneCopyRasterWorkerPool> 134 base::WeakPtrFactory<OneCopyRasterWorkerPool>
122 raster_finished_weak_ptr_factory_; 135 raster_finished_weak_ptr_factory_;
123 136
124 DISALLOW_COPY_AND_ASSIGN(OneCopyRasterWorkerPool); 137 DISALLOW_COPY_AND_ASSIGN(OneCopyRasterWorkerPool);
125 }; 138 };
126 139
127 } // namespace cc 140 } // namespace cc
128 141
129 #endif // CC_RESOURCES_ONE_COPY_RASTER_WORKER_POOL_H_ 142 #endif // CC_RESOURCES_ONE_COPY_RASTER_WORKER_POOL_H_
OLDNEW
« no previous file with comments | « cc/quads/render_pass.cc ('k') | cc/resources/one_copy_raster_worker_pool.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698