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

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

Issue 786583002: cc: Renaming Rasterizer and RasterWorkerPool interfaces (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Fix test. Update include files alphabetic orders. Created 6 years 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
OLDNEW
(Empty)
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
3 // found in the LICENSE file.
4
5 #ifndef CC_RESOURCES_ONE_COPY_RASTER_WORKER_POOL_H_
6 #define CC_RESOURCES_ONE_COPY_RASTER_WORKER_POOL_H_
7
8 #include "base/memory/weak_ptr.h"
9 #include "base/synchronization/lock.h"
10 #include "base/values.h"
11 #include "cc/base/scoped_ptr_deque.h"
12 #include "cc/output/context_provider.h"
13 #include "cc/resources/raster_worker_pool.h"
14 #include "cc/resources/rasterizer.h"
15 #include "cc/resources/resource_provider.h"
16
17 namespace base {
18 namespace debug {
19 class ConvertableToTraceFormat;
20 class TracedValue;
21 }
22 }
23
24 namespace cc {
25 class ResourcePool;
26 class ScopedResource;
27
28 typedef int64 CopySequenceNumber;
29
30 class CC_EXPORT OneCopyRasterWorkerPool : public RasterWorkerPool,
31 public Rasterizer,
32 public RasterizerTaskClient {
33 public:
34 ~OneCopyRasterWorkerPool() override;
35
36 static scoped_ptr<RasterWorkerPool> Create(
37 base::SequencedTaskRunner* task_runner,
38 TaskGraphRunner* task_graph_runner,
39 ContextProvider* context_provider,
40 ResourceProvider* resource_provider,
41 ResourcePool* resource_pool);
42
43 // Overridden from RasterWorkerPool:
44 Rasterizer* AsRasterizer() override;
45
46 // Overridden from Rasterizer:
47 void SetClient(RasterizerClient* client) override;
48 void Shutdown() override;
49 void ScheduleTasks(RasterTaskQueue* queue) override;
50 void CheckForCompletedTasks() override;
51
52 // Overridden from RasterizerTaskClient:
53 scoped_ptr<RasterBuffer> AcquireBufferForRaster(
54 const Resource* resource) override;
55 void ReleaseBufferForRaster(scoped_ptr<RasterBuffer> buffer) override;
56
57 // Playback raster source and schedule copy of |src| resource to |dst|
58 // resource. Returns a non-zero sequence number for this copy operation.
59 CopySequenceNumber PlaybackAndScheduleCopyOnWorkerThread(
60 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock,
61 scoped_ptr<ScopedResource> src,
62 const Resource* dst,
63 const RasterSource* raster_source,
64 const gfx::Rect& rect,
65 float scale);
66
67 // Issues copy operations until |sequence| has been processed. This will
68 // return immediately if |sequence| has already been processed.
69 void AdvanceLastIssuedCopyTo(CopySequenceNumber sequence);
70
71 protected:
72 OneCopyRasterWorkerPool(base::SequencedTaskRunner* task_runner,
73 TaskGraphRunner* task_graph_runner,
74 ContextProvider* context_provider,
75 ResourceProvider* resource_provider,
76 ResourcePool* resource_pool);
77
78 private:
79 struct CopyOperation {
80 typedef ScopedPtrDeque<CopyOperation> Deque;
81
82 CopyOperation(
83 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock,
84 scoped_ptr<ScopedResource> src,
85 const Resource* dst);
86 ~CopyOperation();
87
88 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock;
89 scoped_ptr<ScopedResource> src;
90 const Resource* dst;
91 };
92
93 void OnRasterFinished(TaskSet task_set);
94 void AdvanceLastFlushedCopyTo(CopySequenceNumber sequence);
95 void IssueCopyOperations(int64 count);
96 void ScheduleCheckForCompletedCopyOperationsWithLockAcquired(
97 bool wait_if_needed);
98 void CheckForCompletedCopyOperations(bool wait_if_needed);
99 scoped_refptr<base::debug::ConvertableToTraceFormat> StateAsValue() const;
100 void StagingStateAsValueInto(base::debug::TracedValue* staging_state) const;
101
102 scoped_refptr<base::SequencedTaskRunner> task_runner_;
103 TaskGraphRunner* task_graph_runner_;
104 const NamespaceToken namespace_token_;
105 RasterizerClient* client_;
106 ContextProvider* context_provider_;
107 ResourceProvider* resource_provider_;
108 ResourcePool* resource_pool_;
109 TaskSetCollection raster_pending_;
110 scoped_refptr<RasterizerTask> raster_finished_tasks_[kNumberOfTaskSets];
111 CopySequenceNumber last_issued_copy_operation_;
112 CopySequenceNumber last_flushed_copy_operation_;
113
114 // Task graph used when scheduling tasks and vector used to gather
115 // completed tasks.
116 TaskGraph graph_;
117 Task::Vector completed_tasks_;
118
119 base::Lock lock_;
120 // |lock_| must be acquired when accessing the following members.
121 base::ConditionVariable copy_operation_count_cv_;
122 size_t scheduled_copy_operation_count_;
123 size_t issued_copy_operation_count_;
124 CopyOperation::Deque pending_copy_operations_;
125 CopySequenceNumber next_copy_operation_sequence_;
126 bool check_for_completed_copy_operations_pending_;
127 base::TimeTicks last_check_for_completed_copy_operations_time_;
128 bool shutdown_;
129
130 base::WeakPtrFactory<OneCopyRasterWorkerPool> weak_ptr_factory_;
131 // "raster finished" tasks need their own factory as they need to be
132 // canceled when ScheduleTasks() is called.
133 base::WeakPtrFactory<OneCopyRasterWorkerPool>
134 raster_finished_weak_ptr_factory_;
135
136 DISALLOW_COPY_AND_ASSIGN(OneCopyRasterWorkerPool);
137 };
138
139 } // namespace cc
140
141 #endif // CC_RESOURCES_ONE_COPY_RASTER_WORKER_POOL_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698