• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 // Copyright 2012 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 #include "cc/resources/tile_manager.h"
6 
7 #include <algorithm>
8 #include <limits>
9 #include <string>
10 
11 #include "base/bind.h"
12 #include "base/json/json_writer.h"
13 #include "base/logging.h"
14 #include "base/metrics/histogram.h"
15 #include "cc/debug/devtools_instrumentation.h"
16 #include "cc/debug/frame_viewer_instrumentation.h"
17 #include "cc/debug/traced_value.h"
18 #include "cc/layers/picture_layer_impl.h"
19 #include "cc/resources/raster_worker_pool.h"
20 #include "cc/resources/tile.h"
21 #include "skia/ext/paint_simplifier.h"
22 #include "third_party/skia/include/core/SkBitmap.h"
23 #include "third_party/skia/include/core/SkPixelRef.h"
24 #include "ui/gfx/rect_conversions.h"
25 
26 namespace cc {
27 namespace {
28 
29 // Flag to indicate whether we should try and detect that
30 // a tile is of solid color.
31 const bool kUseColorEstimator = true;
32 
33 class RasterTaskImpl : public RasterTask {
34  public:
RasterTaskImpl(const Resource * resource,PicturePileImpl * picture_pile,const gfx::Rect & content_rect,float contents_scale,RasterMode raster_mode,TileResolution tile_resolution,int layer_id,const void * tile_id,int source_frame_number,bool analyze_picture,RenderingStatsInstrumentation * rendering_stats,const base::Callback<void (const PicturePileImpl::Analysis &,bool)> & reply,ImageDecodeTask::Vector * dependencies)35   RasterTaskImpl(
36       const Resource* resource,
37       PicturePileImpl* picture_pile,
38       const gfx::Rect& content_rect,
39       float contents_scale,
40       RasterMode raster_mode,
41       TileResolution tile_resolution,
42       int layer_id,
43       const void* tile_id,
44       int source_frame_number,
45       bool analyze_picture,
46       RenderingStatsInstrumentation* rendering_stats,
47       const base::Callback<void(const PicturePileImpl::Analysis&, bool)>& reply,
48       ImageDecodeTask::Vector* dependencies)
49       : RasterTask(resource, dependencies),
50         picture_pile_(picture_pile),
51         content_rect_(content_rect),
52         contents_scale_(contents_scale),
53         raster_mode_(raster_mode),
54         tile_resolution_(tile_resolution),
55         layer_id_(layer_id),
56         tile_id_(tile_id),
57         source_frame_number_(source_frame_number),
58         analyze_picture_(analyze_picture),
59         rendering_stats_(rendering_stats),
60         reply_(reply),
61         canvas_(NULL) {}
62 
63   // Overridden from Task:
RunOnWorkerThread()64   virtual void RunOnWorkerThread() OVERRIDE {
65     TRACE_EVENT0("cc", "RasterizerTaskImpl::RunOnWorkerThread");
66 
67     DCHECK(picture_pile_);
68     if (canvas_) {
69       AnalyzeAndRaster(picture_pile_->GetCloneForDrawingOnThread(
70           RasterWorkerPool::GetPictureCloneIndexForCurrentThread()));
71     }
72   }
73 
74   // Overridden from RasterizerTask:
ScheduleOnOriginThread(RasterizerTaskClient * client)75   virtual void ScheduleOnOriginThread(RasterizerTaskClient* client) OVERRIDE {
76     DCHECK(!canvas_);
77     canvas_ = client->AcquireCanvasForRaster(this);
78   }
CompleteOnOriginThread(RasterizerTaskClient * client)79   virtual void CompleteOnOriginThread(RasterizerTaskClient* client) OVERRIDE {
80     canvas_ = NULL;
81     client->ReleaseCanvasForRaster(this);
82   }
RunReplyOnOriginThread()83   virtual void RunReplyOnOriginThread() OVERRIDE {
84     DCHECK(!canvas_);
85     reply_.Run(analysis_, !HasFinishedRunning());
86   }
87 
88  protected:
~RasterTaskImpl()89   virtual ~RasterTaskImpl() { DCHECK(!canvas_); }
90 
91  private:
AnalyzeAndRaster(PicturePileImpl * picture_pile)92   void AnalyzeAndRaster(PicturePileImpl* picture_pile) {
93     DCHECK(picture_pile);
94     DCHECK(canvas_);
95 
96     if (analyze_picture_) {
97       Analyze(picture_pile);
98       if (analysis_.is_solid_color)
99         return;
100     }
101 
102     Raster(picture_pile);
103   }
104 
Analyze(PicturePileImpl * picture_pile)105   void Analyze(PicturePileImpl* picture_pile) {
106     frame_viewer_instrumentation::ScopedAnalyzeTask analyze_task(
107         tile_id_, tile_resolution_, source_frame_number_, layer_id_);
108 
109     DCHECK(picture_pile);
110 
111     picture_pile->AnalyzeInRect(
112         content_rect_, contents_scale_, &analysis_, rendering_stats_);
113 
114     // Record the solid color prediction.
115     UMA_HISTOGRAM_BOOLEAN("Renderer4.SolidColorTilesAnalyzed",
116                           analysis_.is_solid_color);
117 
118     // Clear the flag if we're not using the estimator.
119     analysis_.is_solid_color &= kUseColorEstimator;
120   }
121 
Raster(PicturePileImpl * picture_pile)122   void Raster(PicturePileImpl* picture_pile) {
123     frame_viewer_instrumentation::ScopedRasterTask raster_task(
124         tile_id_,
125         tile_resolution_,
126         source_frame_number_,
127         layer_id_,
128         raster_mode_);
129     devtools_instrumentation::ScopedLayerTask layer_task(
130         devtools_instrumentation::kRasterTask, layer_id_);
131 
132     skia::RefPtr<SkDrawFilter> draw_filter;
133     switch (raster_mode_) {
134       case LOW_QUALITY_RASTER_MODE:
135         draw_filter = skia::AdoptRef(new skia::PaintSimplifier);
136         break;
137       case HIGH_QUALITY_RASTER_MODE:
138         break;
139       case NUM_RASTER_MODES:
140       default:
141         NOTREACHED();
142     }
143     canvas_->setDrawFilter(draw_filter.get());
144 
145     base::TimeDelta prev_rasterize_time =
146         rendering_stats_->impl_thread_rendering_stats().rasterize_time;
147 
148     // Only record rasterization time for highres tiles, because
149     // lowres tiles are not required for activation and therefore
150     // introduce noise in the measurement (sometimes they get rasterized
151     // before we draw and sometimes they aren't)
152     RenderingStatsInstrumentation* stats =
153         tile_resolution_ == HIGH_RESOLUTION ? rendering_stats_ : NULL;
154     DCHECK(picture_pile);
155     picture_pile->RasterToBitmap(
156         canvas_, content_rect_, contents_scale_, stats);
157 
158     if (rendering_stats_->record_rendering_stats()) {
159       base::TimeDelta current_rasterize_time =
160           rendering_stats_->impl_thread_rendering_stats().rasterize_time;
161       HISTOGRAM_CUSTOM_COUNTS(
162           "Renderer4.PictureRasterTimeUS",
163           (current_rasterize_time - prev_rasterize_time).InMicroseconds(),
164           0,
165           100000,
166           100);
167     }
168   }
169 
170   PicturePileImpl::Analysis analysis_;
171   scoped_refptr<PicturePileImpl> picture_pile_;
172   gfx::Rect content_rect_;
173   float contents_scale_;
174   RasterMode raster_mode_;
175   TileResolution tile_resolution_;
176   int layer_id_;
177   const void* tile_id_;
178   int source_frame_number_;
179   bool analyze_picture_;
180   RenderingStatsInstrumentation* rendering_stats_;
181   const base::Callback<void(const PicturePileImpl::Analysis&, bool)> reply_;
182   SkCanvas* canvas_;
183 
184   DISALLOW_COPY_AND_ASSIGN(RasterTaskImpl);
185 };
186 
187 class ImageDecodeTaskImpl : public ImageDecodeTask {
188  public:
ImageDecodeTaskImpl(SkPixelRef * pixel_ref,int layer_id,RenderingStatsInstrumentation * rendering_stats,const base::Callback<void (bool was_canceled)> & reply)189   ImageDecodeTaskImpl(SkPixelRef* pixel_ref,
190                       int layer_id,
191                       RenderingStatsInstrumentation* rendering_stats,
192                       const base::Callback<void(bool was_canceled)>& reply)
193       : pixel_ref_(skia::SharePtr(pixel_ref)),
194         layer_id_(layer_id),
195         rendering_stats_(rendering_stats),
196         reply_(reply) {}
197 
198   // Overridden from Task:
RunOnWorkerThread()199   virtual void RunOnWorkerThread() OVERRIDE {
200     TRACE_EVENT0("cc", "ImageDecodeTaskImpl::RunOnWorkerThread");
201 
202     devtools_instrumentation::ScopedImageDecodeTask image_decode_task(
203         pixel_ref_.get());
204     // This will cause the image referred to by pixel ref to be decoded.
205     pixel_ref_->lockPixels();
206     pixel_ref_->unlockPixels();
207   }
208 
209   // Overridden from RasterizerTask:
ScheduleOnOriginThread(RasterizerTaskClient * client)210   virtual void ScheduleOnOriginThread(RasterizerTaskClient* client) OVERRIDE {}
CompleteOnOriginThread(RasterizerTaskClient * client)211   virtual void CompleteOnOriginThread(RasterizerTaskClient* client) OVERRIDE {}
RunReplyOnOriginThread()212   virtual void RunReplyOnOriginThread() OVERRIDE {
213     reply_.Run(!HasFinishedRunning());
214   }
215 
216  protected:
~ImageDecodeTaskImpl()217   virtual ~ImageDecodeTaskImpl() {}
218 
219  private:
220   skia::RefPtr<SkPixelRef> pixel_ref_;
221   int layer_id_;
222   RenderingStatsInstrumentation* rendering_stats_;
223   const base::Callback<void(bool was_canceled)> reply_;
224 
225   DISALLOW_COPY_AND_ASSIGN(ImageDecodeTaskImpl);
226 };
227 
228 const size_t kScheduledRasterTasksLimit = 32u;
229 
230 // Memory limit policy works by mapping some bin states to the NEVER bin.
231 const ManagedTileBin kBinPolicyMap[NUM_TILE_MEMORY_LIMIT_POLICIES][NUM_BINS] = {
232     // [ALLOW_NOTHING]
233     {NEVER_BIN,  // [NOW_AND_READY_TO_DRAW_BIN]
234      NEVER_BIN,  // [NOW_BIN]
235      NEVER_BIN,  // [SOON_BIN]
236      NEVER_BIN,  // [EVENTUALLY_AND_ACTIVE_BIN]
237      NEVER_BIN,  // [EVENTUALLY_BIN]
238      NEVER_BIN,  // [AT_LAST_AND_ACTIVE_BIN]
239      NEVER_BIN,  // [AT_LAST_BIN]
240      NEVER_BIN   // [NEVER_BIN]
241     },
242     // [ALLOW_ABSOLUTE_MINIMUM]
243     {NOW_AND_READY_TO_DRAW_BIN,  // [NOW_AND_READY_TO_DRAW_BIN]
244      NOW_BIN,                    // [NOW_BIN]
245      NEVER_BIN,                  // [SOON_BIN]
246      NEVER_BIN,                  // [EVENTUALLY_AND_ACTIVE_BIN]
247      NEVER_BIN,                  // [EVENTUALLY_BIN]
248      NEVER_BIN,                  // [AT_LAST_AND_ACTIVE_BIN]
249      NEVER_BIN,                  // [AT_LAST_BIN]
250      NEVER_BIN                   // [NEVER_BIN]
251     },
252     // [ALLOW_PREPAINT_ONLY]
253     {NOW_AND_READY_TO_DRAW_BIN,  // [NOW_AND_READY_TO_DRAW_BIN]
254      NOW_BIN,                    // [NOW_BIN]
255      SOON_BIN,                   // [SOON_BIN]
256      NEVER_BIN,                  // [EVENTUALLY_AND_ACTIVE_BIN]
257      NEVER_BIN,                  // [EVENTUALLY_BIN]
258      NEVER_BIN,                  // [AT_LAST_AND_ACTIVE_BIN]
259      NEVER_BIN,                  // [AT_LAST_BIN]
260      NEVER_BIN                   // [NEVER_BIN]
261     },
262     // [ALLOW_ANYTHING]
263     {NOW_AND_READY_TO_DRAW_BIN,  // [NOW_AND_READY_TO_DRAW_BIN]
264      NOW_BIN,                    // [NOW_BIN]
265      SOON_BIN,                   // [SOON_BIN]
266      EVENTUALLY_AND_ACTIVE_BIN,  // [EVENTUALLY_AND_ACTIVE_BIN]
267      EVENTUALLY_BIN,             // [EVENTUALLY_BIN]
268      AT_LAST_AND_ACTIVE_BIN,     // [AT_LAST_AND_ACTIVE_BIN]
269      AT_LAST_BIN,                // [AT_LAST_BIN]
270      NEVER_BIN                   // [NEVER_BIN]
271     }};
272 
273 // Ready to draw works by mapping NOW_BIN to NOW_AND_READY_TO_DRAW_BIN.
274 const ManagedTileBin kBinReadyToDrawMap[2][NUM_BINS] = {
275     // Not ready
276     {NOW_AND_READY_TO_DRAW_BIN,  // [NOW_AND_READY_TO_DRAW_BIN]
277      NOW_BIN,                    // [NOW_BIN]
278      SOON_BIN,                   // [SOON_BIN]
279      EVENTUALLY_AND_ACTIVE_BIN,  // [EVENTUALLY_AND_ACTIVE_BIN]
280      EVENTUALLY_BIN,             // [EVENTUALLY_BIN]
281      AT_LAST_AND_ACTIVE_BIN,     // [AT_LAST_AND_ACTIVE_BIN]
282      AT_LAST_BIN,                // [AT_LAST_BIN]
283      NEVER_BIN                   // [NEVER_BIN]
284     },
285     // Ready
286     {NOW_AND_READY_TO_DRAW_BIN,  // [NOW_AND_READY_TO_DRAW_BIN]
287      NOW_AND_READY_TO_DRAW_BIN,  // [NOW_BIN]
288      SOON_BIN,                   // [SOON_BIN]
289      EVENTUALLY_AND_ACTIVE_BIN,  // [EVENTUALLY_AND_ACTIVE_BIN]
290      EVENTUALLY_BIN,             // [EVENTUALLY_BIN]
291      AT_LAST_AND_ACTIVE_BIN,     // [AT_LAST_AND_ACTIVE_BIN]
292      AT_LAST_BIN,                // [AT_LAST_BIN]
293      NEVER_BIN                   // [NEVER_BIN]
294     }};
295 
296 // Active works by mapping some bin stats to equivalent _ACTIVE_BIN state.
297 const ManagedTileBin kBinIsActiveMap[2][NUM_BINS] = {
298     // Inactive
299     {NOW_AND_READY_TO_DRAW_BIN,  // [NOW_AND_READY_TO_DRAW_BIN]
300      NOW_BIN,                    // [NOW_BIN]
301      SOON_BIN,                   // [SOON_BIN]
302      EVENTUALLY_AND_ACTIVE_BIN,  // [EVENTUALLY_AND_ACTIVE_BIN]
303      EVENTUALLY_BIN,             // [EVENTUALLY_BIN]
304      AT_LAST_AND_ACTIVE_BIN,     // [AT_LAST_AND_ACTIVE_BIN]
305      AT_LAST_BIN,                // [AT_LAST_BIN]
306      NEVER_BIN                   // [NEVER_BIN]
307     },
308     // Active
309     {NOW_AND_READY_TO_DRAW_BIN,  // [NOW_AND_READY_TO_DRAW_BIN]
310      NOW_BIN,                    // [NOW_BIN]
311      SOON_BIN,                   // [SOON_BIN]
312      EVENTUALLY_AND_ACTIVE_BIN,  // [EVENTUALLY_AND_ACTIVE_BIN]
313      EVENTUALLY_AND_ACTIVE_BIN,  // [EVENTUALLY_BIN]
314      AT_LAST_AND_ACTIVE_BIN,     // [AT_LAST_AND_ACTIVE_BIN]
315      AT_LAST_AND_ACTIVE_BIN,     // [AT_LAST_BIN]
316      NEVER_BIN                   // [NEVER_BIN]
317     }};
318 
319 // Determine bin based on three categories of tiles: things we need now,
320 // things we need soon, and eventually.
BinFromTilePriority(const TilePriority & prio)321 inline ManagedTileBin BinFromTilePriority(const TilePriority& prio) {
322   if (prio.priority_bin == TilePriority::NOW)
323     return NOW_BIN;
324 
325   if (prio.priority_bin == TilePriority::SOON)
326     return SOON_BIN;
327 
328   if (prio.distance_to_visible == std::numeric_limits<float>::infinity())
329     return NEVER_BIN;
330 
331   return EVENTUALLY_BIN;
332 }
333 
334 }  // namespace
335 
RasterTaskCompletionStats()336 RasterTaskCompletionStats::RasterTaskCompletionStats()
337     : completed_count(0u), canceled_count(0u) {}
338 
RasterTaskCompletionStatsAsValue(const RasterTaskCompletionStats & stats)339 scoped_ptr<base::Value> RasterTaskCompletionStatsAsValue(
340     const RasterTaskCompletionStats& stats) {
341   scoped_ptr<base::DictionaryValue> state(new base::DictionaryValue());
342   state->SetInteger("completed_count", stats.completed_count);
343   state->SetInteger("canceled_count", stats.canceled_count);
344   return state.PassAs<base::Value>();
345 }
346 
347 // static
Create(TileManagerClient * client,base::SequencedTaskRunner * task_runner,ResourcePool * resource_pool,Rasterizer * rasterizer,RenderingStatsInstrumentation * rendering_stats_instrumentation)348 scoped_ptr<TileManager> TileManager::Create(
349     TileManagerClient* client,
350     base::SequencedTaskRunner* task_runner,
351     ResourcePool* resource_pool,
352     Rasterizer* rasterizer,
353     RenderingStatsInstrumentation* rendering_stats_instrumentation) {
354   return make_scoped_ptr(new TileManager(client,
355                                          task_runner,
356                                          resource_pool,
357                                          rasterizer,
358                                          rendering_stats_instrumentation));
359 }
360 
TileManager(TileManagerClient * client,base::SequencedTaskRunner * task_runner,ResourcePool * resource_pool,Rasterizer * rasterizer,RenderingStatsInstrumentation * rendering_stats_instrumentation)361 TileManager::TileManager(
362     TileManagerClient* client,
363     base::SequencedTaskRunner* task_runner,
364     ResourcePool* resource_pool,
365     Rasterizer* rasterizer,
366     RenderingStatsInstrumentation* rendering_stats_instrumentation)
367     : client_(client),
368       task_runner_(task_runner),
369       resource_pool_(resource_pool),
370       rasterizer_(rasterizer),
371       prioritized_tiles_dirty_(false),
372       all_tiles_that_need_to_be_rasterized_have_memory_(true),
373       all_tiles_required_for_activation_have_memory_(true),
374       bytes_releasable_(0),
375       resources_releasable_(0),
376       ever_exceeded_memory_budget_(false),
377       rendering_stats_instrumentation_(rendering_stats_instrumentation),
378       did_initialize_visible_tile_(false),
379       did_check_for_completed_tasks_since_last_schedule_tasks_(true),
380       ready_to_activate_check_notifier_(
381           task_runner_,
382           base::Bind(&TileManager::CheckIfReadyToActivate,
383                      base::Unretained(this))) {
384   rasterizer_->SetClient(this);
385 }
386 
~TileManager()387 TileManager::~TileManager() {
388   // Reset global state and manage. This should cause
389   // our memory usage to drop to zero.
390   global_state_ = GlobalStateThatImpactsTilePriority();
391 
392   CleanUpReleasedTiles();
393   DCHECK_EQ(0u, tiles_.size());
394 
395   RasterTaskQueue empty;
396   rasterizer_->ScheduleTasks(&empty);
397   orphan_raster_tasks_.clear();
398 
399   // This should finish all pending tasks and release any uninitialized
400   // resources.
401   rasterizer_->Shutdown();
402   rasterizer_->CheckForCompletedTasks();
403 
404   DCHECK_EQ(0u, bytes_releasable_);
405   DCHECK_EQ(0u, resources_releasable_);
406 }
407 
Release(Tile * tile)408 void TileManager::Release(Tile* tile) {
409   prioritized_tiles_dirty_ = true;
410   released_tiles_.push_back(tile);
411 }
412 
DidChangeTilePriority(Tile * tile)413 void TileManager::DidChangeTilePriority(Tile* tile) {
414   prioritized_tiles_dirty_ = true;
415 }
416 
ShouldForceTasksRequiredForActivationToComplete() const417 bool TileManager::ShouldForceTasksRequiredForActivationToComplete() const {
418   return global_state_.tree_priority != SMOOTHNESS_TAKES_PRIORITY;
419 }
420 
CleanUpReleasedTiles()421 void TileManager::CleanUpReleasedTiles() {
422   for (std::vector<Tile*>::iterator it = released_tiles_.begin();
423        it != released_tiles_.end();
424        ++it) {
425     Tile* tile = *it;
426     ManagedTileState& mts = tile->managed_state();
427 
428     for (int mode = 0; mode < NUM_RASTER_MODES; ++mode) {
429       FreeResourceForTile(tile, static_cast<RasterMode>(mode));
430       orphan_raster_tasks_.push_back(mts.tile_versions[mode].raster_task_);
431     }
432 
433     DCHECK(tiles_.find(tile->id()) != tiles_.end());
434     tiles_.erase(tile->id());
435 
436     LayerCountMap::iterator layer_it =
437         used_layer_counts_.find(tile->layer_id());
438     DCHECK_GT(layer_it->second, 0);
439     if (--layer_it->second == 0) {
440       used_layer_counts_.erase(layer_it);
441       image_decode_tasks_.erase(tile->layer_id());
442     }
443 
444     delete tile;
445   }
446 
447   released_tiles_.clear();
448 }
449 
UpdatePrioritizedTileSetIfNeeded()450 void TileManager::UpdatePrioritizedTileSetIfNeeded() {
451   if (!prioritized_tiles_dirty_)
452     return;
453 
454   CleanUpReleasedTiles();
455 
456   prioritized_tiles_.Clear();
457   GetTilesWithAssignedBins(&prioritized_tiles_);
458   prioritized_tiles_dirty_ = false;
459 }
460 
DidFinishRunningTasks()461 void TileManager::DidFinishRunningTasks() {
462   TRACE_EVENT0("cc", "TileManager::DidFinishRunningTasks");
463 
464   bool memory_usage_above_limit = resource_pool_->total_memory_usage_bytes() >
465                                   global_state_.soft_memory_limit_in_bytes;
466 
467   // When OOM, keep re-assigning memory until we reach a steady state
468   // where top-priority tiles are initialized.
469   if (all_tiles_that_need_to_be_rasterized_have_memory_ &&
470       !memory_usage_above_limit)
471     return;
472 
473   rasterizer_->CheckForCompletedTasks();
474   did_check_for_completed_tasks_since_last_schedule_tasks_ = true;
475 
476   TileVector tiles_that_need_to_be_rasterized;
477   AssignGpuMemoryToTiles(&prioritized_tiles_,
478                          &tiles_that_need_to_be_rasterized);
479 
480   // |tiles_that_need_to_be_rasterized| will be empty when we reach a
481   // steady memory state. Keep scheduling tasks until we reach this state.
482   if (!tiles_that_need_to_be_rasterized.empty()) {
483     ScheduleTasks(tiles_that_need_to_be_rasterized);
484     return;
485   }
486 
487   resource_pool_->ReduceResourceUsage();
488 
489   // We don't reserve memory for required-for-activation tiles during
490   // accelerated gestures, so we just postpone activation when we don't
491   // have these tiles, and activate after the accelerated gesture.
492   bool allow_rasterize_on_demand =
493       global_state_.tree_priority != SMOOTHNESS_TAKES_PRIORITY;
494 
495   // Use on-demand raster for any required-for-activation tiles that have not
496   // been been assigned memory after reaching a steady memory state. This
497   // ensures that we activate even when OOM.
498   for (TileMap::iterator it = tiles_.begin(); it != tiles_.end(); ++it) {
499     Tile* tile = it->second;
500     ManagedTileState& mts = tile->managed_state();
501     ManagedTileState::TileVersion& tile_version =
502         mts.tile_versions[mts.raster_mode];
503 
504     if (tile->required_for_activation() && !tile_version.IsReadyToDraw()) {
505       // If we can't raster on demand, give up early (and don't activate).
506       if (!allow_rasterize_on_demand)
507         return;
508 
509       tile_version.set_rasterize_on_demand();
510       client_->NotifyTileStateChanged(tile);
511     }
512   }
513 
514   DCHECK(IsReadyToActivate());
515   ready_to_activate_check_notifier_.Schedule();
516 }
517 
DidFinishRunningTasksRequiredForActivation()518 void TileManager::DidFinishRunningTasksRequiredForActivation() {
519   // This is only a true indication that all tiles required for
520   // activation are initialized when no tiles are OOM. We need to
521   // wait for DidFinishRunningTasks() to be called, try to re-assign
522   // memory and in worst case use on-demand raster when tiles
523   // required for activation are OOM.
524   if (!all_tiles_required_for_activation_have_memory_)
525     return;
526 
527   ready_to_activate_check_notifier_.Schedule();
528 }
529 
GetTilesWithAssignedBins(PrioritizedTileSet * tiles)530 void TileManager::GetTilesWithAssignedBins(PrioritizedTileSet* tiles) {
531   TRACE_EVENT0("cc", "TileManager::GetTilesWithAssignedBins");
532 
533   const TileMemoryLimitPolicy memory_policy = global_state_.memory_limit_policy;
534   const TreePriority tree_priority = global_state_.tree_priority;
535 
536   // For each tree, bin into different categories of tiles.
537   for (TileMap::const_iterator it = tiles_.begin(); it != tiles_.end(); ++it) {
538     Tile* tile = it->second;
539     ManagedTileState& mts = tile->managed_state();
540 
541     const ManagedTileState::TileVersion& tile_version =
542         tile->GetTileVersionForDrawing();
543     bool tile_is_ready_to_draw = tile_version.IsReadyToDraw();
544     bool tile_is_active = tile_is_ready_to_draw ||
545                           mts.tile_versions[mts.raster_mode].raster_task_;
546 
547     // Get the active priority and bin.
548     TilePriority active_priority = tile->priority(ACTIVE_TREE);
549     ManagedTileBin active_bin = BinFromTilePriority(active_priority);
550 
551     // Get the pending priority and bin.
552     TilePriority pending_priority = tile->priority(PENDING_TREE);
553     ManagedTileBin pending_bin = BinFromTilePriority(pending_priority);
554 
555     bool pending_is_low_res = pending_priority.resolution == LOW_RESOLUTION;
556     bool pending_is_non_ideal =
557         pending_priority.resolution == NON_IDEAL_RESOLUTION;
558     bool active_is_non_ideal =
559         active_priority.resolution == NON_IDEAL_RESOLUTION;
560 
561     // Adjust bin state based on if ready to draw.
562     active_bin = kBinReadyToDrawMap[tile_is_ready_to_draw][active_bin];
563     pending_bin = kBinReadyToDrawMap[tile_is_ready_to_draw][pending_bin];
564 
565     // Adjust bin state based on if active.
566     active_bin = kBinIsActiveMap[tile_is_active][active_bin];
567     pending_bin = kBinIsActiveMap[tile_is_active][pending_bin];
568 
569     // We never want to paint new non-ideal tiles, as we always have
570     // a high-res tile covering that content (paint that instead).
571     if (!tile_is_ready_to_draw && active_is_non_ideal)
572       active_bin = NEVER_BIN;
573     if (!tile_is_ready_to_draw && pending_is_non_ideal)
574       pending_bin = NEVER_BIN;
575 
576     ManagedTileBin tree_bin[NUM_TREES];
577     tree_bin[ACTIVE_TREE] = kBinPolicyMap[memory_policy][active_bin];
578     tree_bin[PENDING_TREE] = kBinPolicyMap[memory_policy][pending_bin];
579 
580     // Adjust pending bin state for low res tiles. This prevents pending tree
581     // low-res tiles from being initialized before high-res tiles.
582     if (pending_is_low_res)
583       tree_bin[PENDING_TREE] = std::max(tree_bin[PENDING_TREE], EVENTUALLY_BIN);
584 
585     TilePriority tile_priority;
586     switch (tree_priority) {
587       case SAME_PRIORITY_FOR_BOTH_TREES:
588         mts.bin = std::min(tree_bin[ACTIVE_TREE], tree_bin[PENDING_TREE]);
589         tile_priority = tile->combined_priority();
590         break;
591       case SMOOTHNESS_TAKES_PRIORITY:
592         mts.bin = tree_bin[ACTIVE_TREE];
593         tile_priority = active_priority;
594         break;
595       case NEW_CONTENT_TAKES_PRIORITY:
596         mts.bin = tree_bin[PENDING_TREE];
597         tile_priority = pending_priority;
598         break;
599     }
600 
601     // Bump up the priority if we determined it's NEVER_BIN on one tree,
602     // but is still required on the other tree.
603     bool is_in_never_bin_on_both_trees = tree_bin[ACTIVE_TREE] == NEVER_BIN &&
604                                          tree_bin[PENDING_TREE] == NEVER_BIN;
605 
606     if (mts.bin == NEVER_BIN && !is_in_never_bin_on_both_trees)
607       mts.bin = tile_is_active ? AT_LAST_AND_ACTIVE_BIN : AT_LAST_BIN;
608 
609     mts.resolution = tile_priority.resolution;
610     mts.priority_bin = tile_priority.priority_bin;
611     mts.distance_to_visible = tile_priority.distance_to_visible;
612     mts.required_for_activation = tile_priority.required_for_activation;
613 
614     mts.visible_and_ready_to_draw =
615         tree_bin[ACTIVE_TREE] == NOW_AND_READY_TO_DRAW_BIN;
616 
617     // Tiles that are required for activation shouldn't be in NEVER_BIN unless
618     // smoothness takes priority or memory policy allows nothing to be
619     // initialized.
620     DCHECK(!mts.required_for_activation || mts.bin != NEVER_BIN ||
621            tree_priority == SMOOTHNESS_TAKES_PRIORITY ||
622            memory_policy == ALLOW_NOTHING);
623 
624     // If the tile is in NEVER_BIN and it does not have an active task, then we
625     // can release the resources early. If it does have the task however, we
626     // should keep it in the prioritized tile set to ensure that AssignGpuMemory
627     // can visit it.
628     if (mts.bin == NEVER_BIN &&
629         !mts.tile_versions[mts.raster_mode].raster_task_) {
630       FreeResourcesForTileAndNotifyClientIfTileWasReadyToDraw(tile);
631       continue;
632     }
633 
634     // Insert the tile into a priority set.
635     tiles->InsertTile(tile, mts.bin);
636   }
637 }
638 
ManageTiles(const GlobalStateThatImpactsTilePriority & state)639 void TileManager::ManageTiles(const GlobalStateThatImpactsTilePriority& state) {
640   TRACE_EVENT0("cc", "TileManager::ManageTiles");
641 
642   // Update internal state.
643   if (state != global_state_) {
644     global_state_ = state;
645     prioritized_tiles_dirty_ = true;
646   }
647 
648   // We need to call CheckForCompletedTasks() once in-between each call
649   // to ScheduleTasks() to prevent canceled tasks from being scheduled.
650   if (!did_check_for_completed_tasks_since_last_schedule_tasks_) {
651     rasterizer_->CheckForCompletedTasks();
652     did_check_for_completed_tasks_since_last_schedule_tasks_ = true;
653   }
654 
655   UpdatePrioritizedTileSetIfNeeded();
656 
657   TileVector tiles_that_need_to_be_rasterized;
658   AssignGpuMemoryToTiles(&prioritized_tiles_,
659                          &tiles_that_need_to_be_rasterized);
660 
661   // Finally, schedule rasterizer tasks.
662   ScheduleTasks(tiles_that_need_to_be_rasterized);
663 
664   TRACE_EVENT_INSTANT1("cc",
665                        "DidManage",
666                        TRACE_EVENT_SCOPE_THREAD,
667                        "state",
668                        TracedValue::FromValue(BasicStateAsValue().release()));
669 
670   TRACE_COUNTER_ID1("cc",
671                     "unused_memory_bytes",
672                     this,
673                     resource_pool_->total_memory_usage_bytes() -
674                         resource_pool_->acquired_memory_usage_bytes());
675 }
676 
UpdateVisibleTiles()677 bool TileManager::UpdateVisibleTiles() {
678   TRACE_EVENT0("cc", "TileManager::UpdateVisibleTiles");
679 
680   rasterizer_->CheckForCompletedTasks();
681   did_check_for_completed_tasks_since_last_schedule_tasks_ = true;
682 
683   TRACE_EVENT_INSTANT1(
684       "cc",
685       "DidUpdateVisibleTiles",
686       TRACE_EVENT_SCOPE_THREAD,
687       "stats",
688       TracedValue::FromValue(RasterTaskCompletionStatsAsValue(
689                                  update_visible_tiles_stats_).release()));
690   update_visible_tiles_stats_ = RasterTaskCompletionStats();
691 
692   bool did_initialize_visible_tile = did_initialize_visible_tile_;
693   did_initialize_visible_tile_ = false;
694   return did_initialize_visible_tile;
695 }
696 
BasicStateAsValue() const697 scoped_ptr<base::Value> TileManager::BasicStateAsValue() const {
698   scoped_ptr<base::DictionaryValue> state(new base::DictionaryValue());
699   state->SetInteger("tile_count", tiles_.size());
700   state->Set("global_state", global_state_.AsValue().release());
701   return state.PassAs<base::Value>();
702 }
703 
AssignGpuMemoryToTiles(PrioritizedTileSet * tiles,TileVector * tiles_that_need_to_be_rasterized)704 void TileManager::AssignGpuMemoryToTiles(
705     PrioritizedTileSet* tiles,
706     TileVector* tiles_that_need_to_be_rasterized) {
707   TRACE_EVENT0("cc", "TileManager::AssignGpuMemoryToTiles");
708 
709   // Maintain the list of released resources that can potentially be re-used
710   // or deleted.
711   // If this operation becomes expensive too, only do this after some
712   // resource(s) was returned. Note that in that case, one also need to
713   // invalidate when releasing some resource from the pool.
714   resource_pool_->CheckBusyResources();
715 
716   // Now give memory out to the tiles until we're out, and build
717   // the needs-to-be-rasterized queue.
718   all_tiles_that_need_to_be_rasterized_have_memory_ = true;
719   all_tiles_required_for_activation_have_memory_ = true;
720 
721   // Cast to prevent overflow.
722   int64 soft_bytes_available =
723       static_cast<int64>(bytes_releasable_) +
724       static_cast<int64>(global_state_.soft_memory_limit_in_bytes) -
725       static_cast<int64>(resource_pool_->acquired_memory_usage_bytes());
726   int64 hard_bytes_available =
727       static_cast<int64>(bytes_releasable_) +
728       static_cast<int64>(global_state_.hard_memory_limit_in_bytes) -
729       static_cast<int64>(resource_pool_->acquired_memory_usage_bytes());
730   int resources_available = resources_releasable_ +
731                             global_state_.num_resources_limit -
732                             resource_pool_->acquired_resource_count();
733   size_t soft_bytes_allocatable =
734       std::max(static_cast<int64>(0), soft_bytes_available);
735   size_t hard_bytes_allocatable =
736       std::max(static_cast<int64>(0), hard_bytes_available);
737   size_t resources_allocatable = std::max(0, resources_available);
738 
739   size_t bytes_that_exceeded_memory_budget = 0;
740   size_t soft_bytes_left = soft_bytes_allocatable;
741   size_t hard_bytes_left = hard_bytes_allocatable;
742 
743   size_t resources_left = resources_allocatable;
744   bool oomed_soft = false;
745   bool oomed_hard = false;
746   bool have_hit_soft_memory = false;  // Soft memory comes after hard.
747 
748   unsigned schedule_priority = 1u;
749   for (PrioritizedTileSet::Iterator it(tiles, true); it; ++it) {
750     Tile* tile = *it;
751     ManagedTileState& mts = tile->managed_state();
752 
753     mts.scheduled_priority = schedule_priority++;
754 
755     mts.raster_mode = tile->DetermineOverallRasterMode();
756 
757     ManagedTileState::TileVersion& tile_version =
758         mts.tile_versions[mts.raster_mode];
759 
760     // If this tile doesn't need a resource, then nothing to do.
761     if (!tile_version.requires_resource())
762       continue;
763 
764     // If the tile is not needed, free it up.
765     if (mts.bin == NEVER_BIN) {
766       FreeResourcesForTileAndNotifyClientIfTileWasReadyToDraw(tile);
767       continue;
768     }
769 
770     const bool tile_uses_hard_limit = mts.bin <= NOW_BIN;
771     const size_t bytes_if_allocated = BytesConsumedIfAllocated(tile);
772     const size_t tile_bytes_left =
773         (tile_uses_hard_limit) ? hard_bytes_left : soft_bytes_left;
774 
775     // Hard-limit is reserved for tiles that would cause a calamity
776     // if they were to go away, so by definition they are the highest
777     // priority memory, and must be at the front of the list.
778     DCHECK(!(have_hit_soft_memory && tile_uses_hard_limit));
779     have_hit_soft_memory |= !tile_uses_hard_limit;
780 
781     size_t tile_bytes = 0;
782     size_t tile_resources = 0;
783 
784     // It costs to maintain a resource.
785     for (int mode = 0; mode < NUM_RASTER_MODES; ++mode) {
786       if (mts.tile_versions[mode].resource_) {
787         tile_bytes += bytes_if_allocated;
788         tile_resources++;
789       }
790     }
791 
792     // Allow lower priority tiles with initialized resources to keep
793     // their memory by only assigning memory to new raster tasks if
794     // they can be scheduled.
795     bool reached_scheduled_raster_tasks_limit =
796         tiles_that_need_to_be_rasterized->size() >= kScheduledRasterTasksLimit;
797     if (!reached_scheduled_raster_tasks_limit) {
798       // If we don't have the required version, and it's not in flight
799       // then we'll have to pay to create a new task.
800       if (!tile_version.resource_ && !tile_version.raster_task_) {
801         tile_bytes += bytes_if_allocated;
802         tile_resources++;
803       }
804     }
805 
806     // Tile is OOM.
807     if (tile_bytes > tile_bytes_left || tile_resources > resources_left) {
808       bool was_ready_to_draw = tile->IsReadyToDraw();
809 
810       FreeResourcesForTile(tile);
811 
812       // This tile was already on screen and now its resources have been
813       // released. In order to prevent checkerboarding, set this tile as
814       // rasterize on demand immediately.
815       if (mts.visible_and_ready_to_draw)
816         tile_version.set_rasterize_on_demand();
817 
818       if (was_ready_to_draw)
819         client_->NotifyTileStateChanged(tile);
820 
821       oomed_soft = true;
822       if (tile_uses_hard_limit) {
823         oomed_hard = true;
824         bytes_that_exceeded_memory_budget += tile_bytes;
825       }
826     } else {
827       resources_left -= tile_resources;
828       hard_bytes_left -= tile_bytes;
829       soft_bytes_left =
830           (soft_bytes_left > tile_bytes) ? soft_bytes_left - tile_bytes : 0;
831       if (tile_version.resource_)
832         continue;
833     }
834 
835     DCHECK(!tile_version.resource_);
836 
837     // Tile shouldn't be rasterized if |tiles_that_need_to_be_rasterized|
838     // has reached it's limit or we've failed to assign gpu memory to this
839     // or any higher priority tile. Preventing tiles that fit into memory
840     // budget to be rasterized when higher priority tile is oom is
841     // important for two reasons:
842     // 1. Tile size should not impact raster priority.
843     // 2. Tiles with existing raster task could otherwise incorrectly
844     //    be added as they are not affected by |bytes_allocatable|.
845     bool can_schedule_tile =
846         !oomed_soft && !reached_scheduled_raster_tasks_limit;
847 
848     if (!can_schedule_tile) {
849       all_tiles_that_need_to_be_rasterized_have_memory_ = false;
850       if (tile->required_for_activation())
851         all_tiles_required_for_activation_have_memory_ = false;
852       it.DisablePriorityOrdering();
853       continue;
854     }
855 
856     tiles_that_need_to_be_rasterized->push_back(tile);
857   }
858 
859   // OOM reporting uses hard-limit, soft-OOM is normal depending on limit.
860   ever_exceeded_memory_budget_ |= oomed_hard;
861   if (ever_exceeded_memory_budget_) {
862     TRACE_COUNTER_ID2("cc",
863                       "over_memory_budget",
864                       this,
865                       "budget",
866                       global_state_.hard_memory_limit_in_bytes,
867                       "over",
868                       bytes_that_exceeded_memory_budget);
869   }
870   memory_stats_from_last_assign_.total_budget_in_bytes =
871       global_state_.hard_memory_limit_in_bytes;
872   memory_stats_from_last_assign_.bytes_allocated =
873       hard_bytes_allocatable - hard_bytes_left;
874   memory_stats_from_last_assign_.bytes_unreleasable =
875       resource_pool_->acquired_memory_usage_bytes() - bytes_releasable_;
876   memory_stats_from_last_assign_.bytes_over = bytes_that_exceeded_memory_budget;
877 }
878 
FreeResourceForTile(Tile * tile,RasterMode mode)879 void TileManager::FreeResourceForTile(Tile* tile, RasterMode mode) {
880   ManagedTileState& mts = tile->managed_state();
881   if (mts.tile_versions[mode].resource_) {
882     resource_pool_->ReleaseResource(mts.tile_versions[mode].resource_.Pass());
883 
884     DCHECK_GE(bytes_releasable_, BytesConsumedIfAllocated(tile));
885     DCHECK_GE(resources_releasable_, 1u);
886 
887     bytes_releasable_ -= BytesConsumedIfAllocated(tile);
888     --resources_releasable_;
889   }
890 }
891 
FreeResourcesForTile(Tile * tile)892 void TileManager::FreeResourcesForTile(Tile* tile) {
893   for (int mode = 0; mode < NUM_RASTER_MODES; ++mode) {
894     FreeResourceForTile(tile, static_cast<RasterMode>(mode));
895   }
896 }
897 
FreeUnusedResourcesForTile(Tile * tile)898 void TileManager::FreeUnusedResourcesForTile(Tile* tile) {
899   DCHECK(tile->IsReadyToDraw());
900   ManagedTileState& mts = tile->managed_state();
901   RasterMode used_mode = LOW_QUALITY_RASTER_MODE;
902   for (int mode = 0; mode < NUM_RASTER_MODES; ++mode) {
903     if (mts.tile_versions[mode].IsReadyToDraw()) {
904       used_mode = static_cast<RasterMode>(mode);
905       break;
906     }
907   }
908 
909   for (int mode = 0; mode < NUM_RASTER_MODES; ++mode) {
910     if (mode != used_mode)
911       FreeResourceForTile(tile, static_cast<RasterMode>(mode));
912   }
913 }
914 
FreeResourcesForTileAndNotifyClientIfTileWasReadyToDraw(Tile * tile)915 void TileManager::FreeResourcesForTileAndNotifyClientIfTileWasReadyToDraw(
916     Tile* tile) {
917   bool was_ready_to_draw = tile->IsReadyToDraw();
918   FreeResourcesForTile(tile);
919   if (was_ready_to_draw)
920     client_->NotifyTileStateChanged(tile);
921 }
922 
ScheduleTasks(const TileVector & tiles_that_need_to_be_rasterized)923 void TileManager::ScheduleTasks(
924     const TileVector& tiles_that_need_to_be_rasterized) {
925   TRACE_EVENT1("cc",
926                "TileManager::ScheduleTasks",
927                "count",
928                tiles_that_need_to_be_rasterized.size());
929 
930   DCHECK(did_check_for_completed_tasks_since_last_schedule_tasks_);
931 
932   raster_queue_.Reset();
933 
934   // Build a new task queue containing all task currently needed. Tasks
935   // are added in order of priority, highest priority task first.
936   for (TileVector::const_iterator it = tiles_that_need_to_be_rasterized.begin();
937        it != tiles_that_need_to_be_rasterized.end();
938        ++it) {
939     Tile* tile = *it;
940     ManagedTileState& mts = tile->managed_state();
941     ManagedTileState::TileVersion& tile_version =
942         mts.tile_versions[mts.raster_mode];
943 
944     DCHECK(tile_version.requires_resource());
945     DCHECK(!tile_version.resource_);
946 
947     if (!tile_version.raster_task_)
948       tile_version.raster_task_ = CreateRasterTask(tile);
949 
950     raster_queue_.items.push_back(RasterTaskQueue::Item(
951         tile_version.raster_task_.get(), tile->required_for_activation()));
952     raster_queue_.required_for_activation_count +=
953         tile->required_for_activation();
954   }
955 
956   // We must reduce the amount of unused resoruces before calling
957   // ScheduleTasks to prevent usage from rising above limits.
958   resource_pool_->ReduceResourceUsage();
959 
960   // Schedule running of |raster_tasks_|. This replaces any previously
961   // scheduled tasks and effectively cancels all tasks not present
962   // in |raster_tasks_|.
963   rasterizer_->ScheduleTasks(&raster_queue_);
964 
965   // It's now safe to clean up orphan tasks as raster worker pool is not
966   // allowed to keep around unreferenced raster tasks after ScheduleTasks() has
967   // been called.
968   orphan_raster_tasks_.clear();
969 
970   did_check_for_completed_tasks_since_last_schedule_tasks_ = false;
971 }
972 
CreateImageDecodeTask(Tile * tile,SkPixelRef * pixel_ref)973 scoped_refptr<ImageDecodeTask> TileManager::CreateImageDecodeTask(
974     Tile* tile,
975     SkPixelRef* pixel_ref) {
976   return make_scoped_refptr(new ImageDecodeTaskImpl(
977       pixel_ref,
978       tile->layer_id(),
979       rendering_stats_instrumentation_,
980       base::Bind(&TileManager::OnImageDecodeTaskCompleted,
981                  base::Unretained(this),
982                  tile->layer_id(),
983                  base::Unretained(pixel_ref))));
984 }
985 
CreateRasterTask(Tile * tile)986 scoped_refptr<RasterTask> TileManager::CreateRasterTask(Tile* tile) {
987   ManagedTileState& mts = tile->managed_state();
988 
989   scoped_ptr<ScopedResource> resource =
990       resource_pool_->AcquireResource(tile->tile_size_.size());
991   const ScopedResource* const_resource = resource.get();
992 
993   // Create and queue all image decode tasks that this tile depends on.
994   ImageDecodeTask::Vector decode_tasks;
995   PixelRefTaskMap& existing_pixel_refs = image_decode_tasks_[tile->layer_id()];
996   for (PicturePileImpl::PixelRefIterator iter(
997            tile->content_rect(), tile->contents_scale(), tile->picture_pile());
998        iter;
999        ++iter) {
1000     SkPixelRef* pixel_ref = *iter;
1001     uint32_t id = pixel_ref->getGenerationID();
1002 
1003     // Append existing image decode task if available.
1004     PixelRefTaskMap::iterator decode_task_it = existing_pixel_refs.find(id);
1005     if (decode_task_it != existing_pixel_refs.end()) {
1006       decode_tasks.push_back(decode_task_it->second);
1007       continue;
1008     }
1009 
1010     // Create and append new image decode task for this pixel ref.
1011     scoped_refptr<ImageDecodeTask> decode_task =
1012         CreateImageDecodeTask(tile, pixel_ref);
1013     decode_tasks.push_back(decode_task);
1014     existing_pixel_refs[id] = decode_task;
1015   }
1016 
1017   return make_scoped_refptr(
1018       new RasterTaskImpl(const_resource,
1019                          tile->picture_pile(),
1020                          tile->content_rect(),
1021                          tile->contents_scale(),
1022                          mts.raster_mode,
1023                          mts.resolution,
1024                          tile->layer_id(),
1025                          static_cast<const void*>(tile),
1026                          tile->source_frame_number(),
1027                          tile->use_picture_analysis(),
1028                          rendering_stats_instrumentation_,
1029                          base::Bind(&TileManager::OnRasterTaskCompleted,
1030                                     base::Unretained(this),
1031                                     tile->id(),
1032                                     base::Passed(&resource),
1033                                     mts.raster_mode),
1034                          &decode_tasks));
1035 }
1036 
OnImageDecodeTaskCompleted(int layer_id,SkPixelRef * pixel_ref,bool was_canceled)1037 void TileManager::OnImageDecodeTaskCompleted(int layer_id,
1038                                              SkPixelRef* pixel_ref,
1039                                              bool was_canceled) {
1040   // If the task was canceled, we need to clean it up
1041   // from |image_decode_tasks_|.
1042   if (!was_canceled)
1043     return;
1044 
1045   LayerPixelRefTaskMap::iterator layer_it = image_decode_tasks_.find(layer_id);
1046   if (layer_it == image_decode_tasks_.end())
1047     return;
1048 
1049   PixelRefTaskMap& pixel_ref_tasks = layer_it->second;
1050   PixelRefTaskMap::iterator task_it =
1051       pixel_ref_tasks.find(pixel_ref->getGenerationID());
1052 
1053   if (task_it != pixel_ref_tasks.end())
1054     pixel_ref_tasks.erase(task_it);
1055 }
1056 
OnRasterTaskCompleted(Tile::Id tile_id,scoped_ptr<ScopedResource> resource,RasterMode raster_mode,const PicturePileImpl::Analysis & analysis,bool was_canceled)1057 void TileManager::OnRasterTaskCompleted(
1058     Tile::Id tile_id,
1059     scoped_ptr<ScopedResource> resource,
1060     RasterMode raster_mode,
1061     const PicturePileImpl::Analysis& analysis,
1062     bool was_canceled) {
1063   TileMap::iterator it = tiles_.find(tile_id);
1064   if (it == tiles_.end()) {
1065     ++update_visible_tiles_stats_.canceled_count;
1066     resource_pool_->ReleaseResource(resource.Pass());
1067     return;
1068   }
1069 
1070   Tile* tile = it->second;
1071   ManagedTileState& mts = tile->managed_state();
1072   ManagedTileState::TileVersion& tile_version = mts.tile_versions[raster_mode];
1073   DCHECK(tile_version.raster_task_);
1074   orphan_raster_tasks_.push_back(tile_version.raster_task_);
1075   tile_version.raster_task_ = NULL;
1076 
1077   if (was_canceled) {
1078     ++update_visible_tiles_stats_.canceled_count;
1079     resource_pool_->ReleaseResource(resource.Pass());
1080     return;
1081   }
1082 
1083   ++update_visible_tiles_stats_.completed_count;
1084 
1085   if (analysis.is_solid_color) {
1086     tile_version.set_solid_color(analysis.solid_color);
1087     resource_pool_->ReleaseResource(resource.Pass());
1088   } else {
1089     tile_version.set_use_resource();
1090     tile_version.resource_ = resource.Pass();
1091 
1092     bytes_releasable_ += BytesConsumedIfAllocated(tile);
1093     ++resources_releasable_;
1094   }
1095 
1096   FreeUnusedResourcesForTile(tile);
1097   if (tile->priority(ACTIVE_TREE).distance_to_visible == 0.f)
1098     did_initialize_visible_tile_ = true;
1099 
1100   client_->NotifyTileStateChanged(tile);
1101 }
1102 
CreateTile(PicturePileImpl * picture_pile,const gfx::Size & tile_size,const gfx::Rect & content_rect,const gfx::Rect & opaque_rect,float contents_scale,int layer_id,int source_frame_number,int flags)1103 scoped_refptr<Tile> TileManager::CreateTile(PicturePileImpl* picture_pile,
1104                                             const gfx::Size& tile_size,
1105                                             const gfx::Rect& content_rect,
1106                                             const gfx::Rect& opaque_rect,
1107                                             float contents_scale,
1108                                             int layer_id,
1109                                             int source_frame_number,
1110                                             int flags) {
1111   scoped_refptr<Tile> tile = make_scoped_refptr(new Tile(this,
1112                                                          picture_pile,
1113                                                          tile_size,
1114                                                          content_rect,
1115                                                          opaque_rect,
1116                                                          contents_scale,
1117                                                          layer_id,
1118                                                          source_frame_number,
1119                                                          flags));
1120   DCHECK(tiles_.find(tile->id()) == tiles_.end());
1121 
1122   tiles_[tile->id()] = tile;
1123   used_layer_counts_[tile->layer_id()]++;
1124   prioritized_tiles_dirty_ = true;
1125   return tile;
1126 }
1127 
GetPairedPictureLayers(std::vector<PairedPictureLayer> * paired_layers) const1128 void TileManager::GetPairedPictureLayers(
1129     std::vector<PairedPictureLayer>* paired_layers) const {
1130   const std::vector<PictureLayerImpl*>& layers = client_->GetPictureLayers();
1131 
1132   paired_layers->clear();
1133   // Reserve a maximum possible paired layers.
1134   paired_layers->reserve(layers.size());
1135 
1136   for (std::vector<PictureLayerImpl*>::const_iterator it = layers.begin();
1137        it != layers.end();
1138        ++it) {
1139     PictureLayerImpl* layer = *it;
1140 
1141     // TODO(vmpstr): Iterators and should handle this instead. crbug.com/381704
1142     if (!layer->HasValidTilePriorities())
1143       continue;
1144 
1145     PictureLayerImpl* twin_layer = layer->GetTwinLayer();
1146 
1147     // Ignore the twin layer when tile priorities are invalid.
1148     // TODO(vmpstr): Iterators should handle this instead. crbug.com/381704
1149     if (twin_layer && !twin_layer->HasValidTilePriorities())
1150       twin_layer = NULL;
1151 
1152     PairedPictureLayer paired_layer;
1153     WhichTree tree = layer->GetTree();
1154 
1155     // If the current tree is ACTIVE_TREE, then always generate a paired_layer.
1156     // If current tree is PENDING_TREE, then only generate a paired_layer if
1157     // there is no twin layer.
1158     if (tree == ACTIVE_TREE) {
1159       DCHECK(!twin_layer || twin_layer->GetTree() == PENDING_TREE);
1160       paired_layer.active_layer = layer;
1161       paired_layer.pending_layer = twin_layer;
1162       paired_layers->push_back(paired_layer);
1163     } else if (!twin_layer) {
1164       paired_layer.active_layer = NULL;
1165       paired_layer.pending_layer = layer;
1166       paired_layers->push_back(paired_layer);
1167     }
1168   }
1169 }
1170 
PairedPictureLayer()1171 TileManager::PairedPictureLayer::PairedPictureLayer()
1172     : active_layer(NULL), pending_layer(NULL) {}
1173 
~PairedPictureLayer()1174 TileManager::PairedPictureLayer::~PairedPictureLayer() {}
1175 
RasterTileIterator(TileManager * tile_manager,TreePriority tree_priority)1176 TileManager::RasterTileIterator::RasterTileIterator(TileManager* tile_manager,
1177                                                     TreePriority tree_priority)
1178     : tree_priority_(tree_priority), comparator_(tree_priority) {
1179   std::vector<TileManager::PairedPictureLayer> paired_layers;
1180   tile_manager->GetPairedPictureLayers(&paired_layers);
1181   bool prioritize_low_res = tree_priority_ == SMOOTHNESS_TAKES_PRIORITY;
1182 
1183   paired_iterators_.reserve(paired_layers.size());
1184   iterator_heap_.reserve(paired_layers.size());
1185   for (std::vector<TileManager::PairedPictureLayer>::iterator it =
1186            paired_layers.begin();
1187        it != paired_layers.end();
1188        ++it) {
1189     PairedPictureLayerIterator paired_iterator;
1190     if (it->active_layer) {
1191       paired_iterator.active_iterator =
1192           PictureLayerImpl::LayerRasterTileIterator(it->active_layer,
1193                                                     prioritize_low_res);
1194     }
1195 
1196     if (it->pending_layer) {
1197       paired_iterator.pending_iterator =
1198           PictureLayerImpl::LayerRasterTileIterator(it->pending_layer,
1199                                                     prioritize_low_res);
1200     }
1201 
1202     if (paired_iterator.PeekTile(tree_priority_) != NULL) {
1203       paired_iterators_.push_back(paired_iterator);
1204       iterator_heap_.push_back(&paired_iterators_.back());
1205     }
1206   }
1207 
1208   std::make_heap(iterator_heap_.begin(), iterator_heap_.end(), comparator_);
1209 }
1210 
~RasterTileIterator()1211 TileManager::RasterTileIterator::~RasterTileIterator() {}
1212 
operator ++()1213 TileManager::RasterTileIterator& TileManager::RasterTileIterator::operator++() {
1214   DCHECK(*this);
1215 
1216   std::pop_heap(iterator_heap_.begin(), iterator_heap_.end(), comparator_);
1217   PairedPictureLayerIterator* paired_iterator = iterator_heap_.back();
1218   iterator_heap_.pop_back();
1219 
1220   paired_iterator->PopTile(tree_priority_);
1221   if (paired_iterator->PeekTile(tree_priority_) != NULL) {
1222     iterator_heap_.push_back(paired_iterator);
1223     std::push_heap(iterator_heap_.begin(), iterator_heap_.end(), comparator_);
1224   }
1225   return *this;
1226 }
1227 
operator bool() const1228 TileManager::RasterTileIterator::operator bool() const {
1229   return !iterator_heap_.empty();
1230 }
1231 
operator *()1232 Tile* TileManager::RasterTileIterator::operator*() {
1233   DCHECK(*this);
1234   return iterator_heap_.front()->PeekTile(tree_priority_);
1235 }
1236 
1237 TileManager::RasterTileIterator::PairedPictureLayerIterator::
PairedPictureLayerIterator()1238     PairedPictureLayerIterator() {}
1239 
1240 TileManager::RasterTileIterator::PairedPictureLayerIterator::
~PairedPictureLayerIterator()1241     ~PairedPictureLayerIterator() {}
1242 
PeekTile(TreePriority tree_priority)1243 Tile* TileManager::RasterTileIterator::PairedPictureLayerIterator::PeekTile(
1244     TreePriority tree_priority) {
1245   PictureLayerImpl::LayerRasterTileIterator* next_iterator =
1246       NextTileIterator(tree_priority).first;
1247   if (!next_iterator)
1248     return NULL;
1249 
1250   DCHECK(*next_iterator);
1251   DCHECK(std::find(returned_shared_tiles.begin(),
1252                    returned_shared_tiles.end(),
1253                    **next_iterator) == returned_shared_tiles.end());
1254   return **next_iterator;
1255 }
1256 
PopTile(TreePriority tree_priority)1257 void TileManager::RasterTileIterator::PairedPictureLayerIterator::PopTile(
1258     TreePriority tree_priority) {
1259   PictureLayerImpl::LayerRasterTileIterator* next_iterator =
1260       NextTileIterator(tree_priority).first;
1261   DCHECK(next_iterator);
1262   DCHECK(*next_iterator);
1263   returned_shared_tiles.push_back(**next_iterator);
1264   ++(*next_iterator);
1265 
1266   next_iterator = NextTileIterator(tree_priority).first;
1267   while (next_iterator &&
1268          std::find(returned_shared_tiles.begin(),
1269                    returned_shared_tiles.end(),
1270                    **next_iterator) != returned_shared_tiles.end()) {
1271     ++(*next_iterator);
1272     next_iterator = NextTileIterator(tree_priority).first;
1273   }
1274 }
1275 
1276 std::pair<PictureLayerImpl::LayerRasterTileIterator*, WhichTree>
NextTileIterator(TreePriority tree_priority)1277 TileManager::RasterTileIterator::PairedPictureLayerIterator::NextTileIterator(
1278     TreePriority tree_priority) {
1279   // If both iterators are out of tiles, return NULL.
1280   if (!active_iterator && !pending_iterator) {
1281     return std::pair<PictureLayerImpl::LayerRasterTileIterator*, WhichTree>(
1282         NULL, ACTIVE_TREE);
1283   }
1284 
1285   // If we only have one iterator with tiles, return it.
1286   if (!active_iterator)
1287     return std::make_pair(&pending_iterator, PENDING_TREE);
1288   if (!pending_iterator)
1289     return std::make_pair(&active_iterator, ACTIVE_TREE);
1290 
1291   // Now both iterators have tiles, so we have to decide based on tree priority.
1292   switch (tree_priority) {
1293     case SMOOTHNESS_TAKES_PRIORITY:
1294       return std::make_pair(&active_iterator, ACTIVE_TREE);
1295     case NEW_CONTENT_TAKES_PRIORITY:
1296       return std::make_pair(&pending_iterator, ACTIVE_TREE);
1297     case SAME_PRIORITY_FOR_BOTH_TREES: {
1298       Tile* active_tile = *active_iterator;
1299       Tile* pending_tile = *pending_iterator;
1300       if (active_tile == pending_tile)
1301         return std::make_pair(&active_iterator, ACTIVE_TREE);
1302 
1303       const TilePriority& active_priority = active_tile->priority(ACTIVE_TREE);
1304       const TilePriority& pending_priority =
1305           pending_tile->priority(PENDING_TREE);
1306 
1307       if (active_priority.IsHigherPriorityThan(pending_priority))
1308         return std::make_pair(&active_iterator, ACTIVE_TREE);
1309       return std::make_pair(&pending_iterator, PENDING_TREE);
1310     }
1311   }
1312 
1313   NOTREACHED();
1314   // Keep the compiler happy.
1315   return std::pair<PictureLayerImpl::LayerRasterTileIterator*, WhichTree>(
1316       NULL, ACTIVE_TREE);
1317 }
1318 
RasterOrderComparator(TreePriority tree_priority)1319 TileManager::RasterTileIterator::RasterOrderComparator::RasterOrderComparator(
1320     TreePriority tree_priority)
1321     : tree_priority_(tree_priority) {}
1322 
operator ()(PairedPictureLayerIterator * a,PairedPictureLayerIterator * b) const1323 bool TileManager::RasterTileIterator::RasterOrderComparator::operator()(
1324     PairedPictureLayerIterator* a,
1325     PairedPictureLayerIterator* b) const {
1326   std::pair<PictureLayerImpl::LayerRasterTileIterator*, WhichTree> a_pair =
1327       a->NextTileIterator(tree_priority_);
1328   DCHECK(a_pair.first);
1329   DCHECK(*a_pair.first);
1330 
1331   std::pair<PictureLayerImpl::LayerRasterTileIterator*, WhichTree> b_pair =
1332       b->NextTileIterator(tree_priority_);
1333   DCHECK(b_pair.first);
1334   DCHECK(*b_pair.first);
1335 
1336   Tile* a_tile = **a_pair.first;
1337   Tile* b_tile = **b_pair.first;
1338 
1339   const TilePriority& a_priority =
1340       a_tile->priority_for_tree_priority(tree_priority_);
1341   const TilePriority& b_priority =
1342       b_tile->priority_for_tree_priority(tree_priority_);
1343   bool prioritize_low_res = tree_priority_ == SMOOTHNESS_TAKES_PRIORITY;
1344 
1345   // Now we have to return true iff b is higher priority than a.
1346 
1347   // If the bin is the same but the resolution is not, then the order will be
1348   // determined by whether we prioritize low res or not.
1349   // TODO(vmpstr): Remove this when TilePriority is no longer a member of Tile
1350   // class but instead produced by the iterators.
1351   if (b_priority.priority_bin == a_priority.priority_bin &&
1352       b_priority.resolution != a_priority.resolution) {
1353     // Non ideal resolution should be sorted lower than other resolutions.
1354     if (a_priority.resolution == NON_IDEAL_RESOLUTION)
1355       return true;
1356 
1357     if (b_priority.resolution == NON_IDEAL_RESOLUTION)
1358       return false;
1359 
1360     if (prioritize_low_res)
1361       return b_priority.resolution == LOW_RESOLUTION;
1362 
1363     return b_priority.resolution == HIGH_RESOLUTION;
1364   }
1365 
1366   return b_priority.IsHigherPriorityThan(a_priority);
1367 }
1368 
EvictionTileIterator()1369 TileManager::EvictionTileIterator::EvictionTileIterator()
1370     : comparator_(SAME_PRIORITY_FOR_BOTH_TREES) {}
1371 
EvictionTileIterator(TileManager * tile_manager,TreePriority tree_priority)1372 TileManager::EvictionTileIterator::EvictionTileIterator(
1373     TileManager* tile_manager,
1374     TreePriority tree_priority)
1375     : tree_priority_(tree_priority), comparator_(tree_priority) {
1376   std::vector<TileManager::PairedPictureLayer> paired_layers;
1377 
1378   tile_manager->GetPairedPictureLayers(&paired_layers);
1379 
1380   paired_iterators_.reserve(paired_layers.size());
1381   iterator_heap_.reserve(paired_layers.size());
1382   for (std::vector<TileManager::PairedPictureLayer>::iterator it =
1383            paired_layers.begin();
1384        it != paired_layers.end();
1385        ++it) {
1386     PairedPictureLayerIterator paired_iterator;
1387     if (it->active_layer) {
1388       paired_iterator.active_iterator =
1389           PictureLayerImpl::LayerEvictionTileIterator(it->active_layer,
1390                                                       tree_priority_);
1391     }
1392 
1393     if (it->pending_layer) {
1394       paired_iterator.pending_iterator =
1395           PictureLayerImpl::LayerEvictionTileIterator(it->pending_layer,
1396                                                       tree_priority_);
1397     }
1398 
1399     if (paired_iterator.PeekTile(tree_priority_) != NULL) {
1400       paired_iterators_.push_back(paired_iterator);
1401       iterator_heap_.push_back(&paired_iterators_.back());
1402     }
1403   }
1404 
1405   std::make_heap(iterator_heap_.begin(), iterator_heap_.end(), comparator_);
1406 }
1407 
~EvictionTileIterator()1408 TileManager::EvictionTileIterator::~EvictionTileIterator() {}
1409 
1410 TileManager::EvictionTileIterator& TileManager::EvictionTileIterator::
operator ++()1411 operator++() {
1412   std::pop_heap(iterator_heap_.begin(), iterator_heap_.end(), comparator_);
1413   PairedPictureLayerIterator* paired_iterator = iterator_heap_.back();
1414   iterator_heap_.pop_back();
1415 
1416   paired_iterator->PopTile(tree_priority_);
1417   if (paired_iterator->PeekTile(tree_priority_) != NULL) {
1418     iterator_heap_.push_back(paired_iterator);
1419     std::push_heap(iterator_heap_.begin(), iterator_heap_.end(), comparator_);
1420   }
1421   return *this;
1422 }
1423 
operator bool() const1424 TileManager::EvictionTileIterator::operator bool() const {
1425   return !iterator_heap_.empty();
1426 }
1427 
operator *()1428 Tile* TileManager::EvictionTileIterator::operator*() {
1429   DCHECK(*this);
1430   return iterator_heap_.front()->PeekTile(tree_priority_);
1431 }
1432 
1433 TileManager::EvictionTileIterator::PairedPictureLayerIterator::
PairedPictureLayerIterator()1434     PairedPictureLayerIterator() {}
1435 
1436 TileManager::EvictionTileIterator::PairedPictureLayerIterator::
~PairedPictureLayerIterator()1437     ~PairedPictureLayerIterator() {}
1438 
PeekTile(TreePriority tree_priority)1439 Tile* TileManager::EvictionTileIterator::PairedPictureLayerIterator::PeekTile(
1440     TreePriority tree_priority) {
1441   PictureLayerImpl::LayerEvictionTileIterator* next_iterator =
1442       NextTileIterator(tree_priority);
1443   if (!next_iterator)
1444     return NULL;
1445 
1446   DCHECK(*next_iterator);
1447   DCHECK(std::find(returned_shared_tiles.begin(),
1448                    returned_shared_tiles.end(),
1449                    **next_iterator) == returned_shared_tiles.end());
1450   return **next_iterator;
1451 }
1452 
PopTile(TreePriority tree_priority)1453 void TileManager::EvictionTileIterator::PairedPictureLayerIterator::PopTile(
1454     TreePriority tree_priority) {
1455   PictureLayerImpl::LayerEvictionTileIterator* next_iterator =
1456       NextTileIterator(tree_priority);
1457   DCHECK(next_iterator);
1458   DCHECK(*next_iterator);
1459   returned_shared_tiles.push_back(**next_iterator);
1460   ++(*next_iterator);
1461 
1462   next_iterator = NextTileIterator(tree_priority);
1463   while (next_iterator &&
1464          std::find(returned_shared_tiles.begin(),
1465                    returned_shared_tiles.end(),
1466                    **next_iterator) != returned_shared_tiles.end()) {
1467     ++(*next_iterator);
1468     next_iterator = NextTileIterator(tree_priority);
1469   }
1470 }
1471 
1472 PictureLayerImpl::LayerEvictionTileIterator*
NextTileIterator(TreePriority tree_priority)1473 TileManager::EvictionTileIterator::PairedPictureLayerIterator::NextTileIterator(
1474     TreePriority tree_priority) {
1475   // If both iterators are out of tiles, return NULL.
1476   if (!active_iterator && !pending_iterator)
1477     return NULL;
1478 
1479   // If we only have one iterator with tiles, return it.
1480   if (!active_iterator)
1481     return &pending_iterator;
1482   if (!pending_iterator)
1483     return &active_iterator;
1484 
1485   Tile* active_tile = *active_iterator;
1486   Tile* pending_tile = *pending_iterator;
1487   if (active_tile == pending_tile)
1488     return &active_iterator;
1489 
1490   const TilePriority& active_priority =
1491       active_tile->priority_for_tree_priority(tree_priority);
1492   const TilePriority& pending_priority =
1493       pending_tile->priority_for_tree_priority(tree_priority);
1494 
1495   if (pending_priority.IsHigherPriorityThan(active_priority))
1496     return &active_iterator;
1497   return &pending_iterator;
1498 }
1499 
1500 TileManager::EvictionTileIterator::EvictionOrderComparator::
EvictionOrderComparator(TreePriority tree_priority)1501     EvictionOrderComparator(TreePriority tree_priority)
1502     : tree_priority_(tree_priority) {}
1503 
operator ()(PairedPictureLayerIterator * a,PairedPictureLayerIterator * b) const1504 bool TileManager::EvictionTileIterator::EvictionOrderComparator::operator()(
1505     PairedPictureLayerIterator* a,
1506     PairedPictureLayerIterator* b) const {
1507   PictureLayerImpl::LayerEvictionTileIterator* a_iterator =
1508       a->NextTileIterator(tree_priority_);
1509   DCHECK(a_iterator);
1510   DCHECK(*a_iterator);
1511 
1512   PictureLayerImpl::LayerEvictionTileIterator* b_iterator =
1513       b->NextTileIterator(tree_priority_);
1514   DCHECK(b_iterator);
1515   DCHECK(*b_iterator);
1516 
1517   Tile* a_tile = **a_iterator;
1518   Tile* b_tile = **b_iterator;
1519 
1520   const TilePriority& a_priority =
1521       a_tile->priority_for_tree_priority(tree_priority_);
1522   const TilePriority& b_priority =
1523       b_tile->priority_for_tree_priority(tree_priority_);
1524   bool prioritize_low_res = tree_priority_ == SMOOTHNESS_TAKES_PRIORITY;
1525 
1526   // Now we have to return true iff b is lower priority than a.
1527 
1528   // If the bin is the same but the resolution is not, then the order will be
1529   // determined by whether we prioritize low res or not.
1530   // TODO(vmpstr): Remove this when TilePriority is no longer a member of Tile
1531   // class but instead produced by the iterators.
1532   if (b_priority.priority_bin == a_priority.priority_bin &&
1533       b_priority.resolution != a_priority.resolution) {
1534     // Non ideal resolution should be sorted higher than other resolutions.
1535     if (a_priority.resolution == NON_IDEAL_RESOLUTION)
1536       return false;
1537 
1538     if (b_priority.resolution == NON_IDEAL_RESOLUTION)
1539       return true;
1540 
1541     if (prioritize_low_res)
1542       return a_priority.resolution == LOW_RESOLUTION;
1543 
1544     return a_priority.resolution == HIGH_RESOLUTION;
1545   }
1546   return a_priority.IsHigherPriorityThan(b_priority);
1547 }
1548 
SetRasterizerForTesting(Rasterizer * rasterizer)1549 void TileManager::SetRasterizerForTesting(Rasterizer* rasterizer) {
1550   rasterizer_ = rasterizer;
1551   rasterizer_->SetClient(this);
1552 }
1553 
IsReadyToActivate() const1554 bool TileManager::IsReadyToActivate() const {
1555   const std::vector<PictureLayerImpl*>& layers = client_->GetPictureLayers();
1556 
1557   for (std::vector<PictureLayerImpl*>::const_iterator it = layers.begin();
1558        it != layers.end();
1559        ++it) {
1560     if (!(*it)->AllTilesRequiredForActivationAreReadyToDraw())
1561       return false;
1562   }
1563 
1564   return true;
1565 }
1566 
CheckIfReadyToActivate()1567 void TileManager::CheckIfReadyToActivate() {
1568   TRACE_EVENT0("cc", "TileManager::CheckIfReadyToActivate");
1569 
1570   rasterizer_->CheckForCompletedTasks();
1571   did_check_for_completed_tasks_since_last_schedule_tasks_ = true;
1572 
1573   if (IsReadyToActivate())
1574     client_->NotifyReadyToActivate();
1575 }
1576 
1577 }  // namespace cc
1578