src/cc/resources/pixel_buffer_raster_worker_pool.h

   1 // Copyright 2013 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_PIXEL_BUFFER_RASTER_WORKER_POOL_H_
   6 #define CC_RESOURCES_PIXEL_BUFFER_RASTER_WORKER_POOL_H_
   7
   8 #include <deque>
   9 #include <set>
  10 #include <vector>
  11
  12 #include "base/containers/hash_tables.h"
  13 #include "cc/resources/raster_worker_pool.h"
  14
  15 namespace cc {
  16
  17 class CC_EXPORT PixelBufferRasterWorkerPool : public RasterWorkerPool {
  18  public:
  19   virtual ~PixelBufferRasterWorkerPool();
  20
  21   static scoped_ptr<RasterWorkerPool> Create(
  22       ResourceProvider* resource_provider,
  23       size_t num_threads,
  24       size_t max_transfer_buffer_usage_bytes) {
  25     return make_scoped_ptr<RasterWorkerPool>(
  26         new PixelBufferRasterWorkerPool(resource_provider,
  27                                         num_threads,
  28                                         max_transfer_buffer_usage_bytes));
  29   }
  30
  31   // Overridden from WorkerPool:
  32   virtual void Shutdown() OVERRIDE;
  33   virtual void CheckForCompletedTasks() OVERRIDE;
  34
  35   // Overridden from RasterWorkerPool:
  36   virtual void ScheduleTasks(RasterTask::Queue* queue) OVERRIDE;
  37   virtual ResourceFormat GetResourceFormat() const OVERRIDE;
  38   virtual void OnRasterTasksFinished() OVERRIDE;
  39   virtual void OnRasterTasksRequiredForActivationFinished() OVERRIDE;
  40
  41  private:
  42   PixelBufferRasterWorkerPool(ResourceProvider* resource_provider,
  43                               size_t num_threads,
  44                               size_t max_transfer_buffer_usage_bytes);
  45
  46   void FlushUploads();
  47   void CheckForCompletedUploads();
  48   void ScheduleCheckForCompletedRasterTasks();
  49   void CheckForCompletedRasterTasks();
  50   void ScheduleMoreTasks();
  51   void OnRasterTaskCompleted(
  52       scoped_refptr<internal::RasterWorkerPoolTask> task,
  53       bool was_canceled,
  54       bool needs_upload);
  55   void DidCompleteRasterTask(internal::RasterWorkerPoolTask* task);
  56   unsigned PendingRasterTaskCount() const;
  57   bool HasPendingTasks() const;
  58   bool HasPendingTasksRequiredForActivation() const;
  59
  60   const char* StateName() const;
  61   scoped_ptr<base::Value> StateAsValue() const;
  62   scoped_ptr<base::Value> ThrottleStateAsValue() const;
  63
  64   bool shutdown_;
  65
  66   TaskMap pixel_buffer_tasks_;
  67
  68   typedef std::deque<scoped_refptr<internal::RasterWorkerPoolTask> > TaskDeque;
  69   TaskDeque tasks_with_pending_upload_;
  70   TaskDeque completed_tasks_;
  71
  72   typedef base::hash_set<internal::RasterWorkerPoolTask*> TaskSet;
  73   TaskSet tasks_required_for_activation_;
  74
  75   size_t scheduled_raster_task_count_;
  76   size_t bytes_pending_upload_;
  77   size_t max_bytes_pending_upload_;
  78   bool has_performed_uploads_since_last_flush_;
  79   base::CancelableClosure check_for_completed_raster_tasks_callback_;
  80   bool check_for_completed_raster_tasks_pending_;
  81
  82   bool should_notify_client_if_no_tasks_are_pending_;
  83   bool should_notify_client_if_no_tasks_required_for_activation_are_pending_;
  84   ResourceFormat format_;
  85
  86   DISALLOW_COPY_AND_ASSIGN(PixelBufferRasterWorkerPool);
  87 };
  88
  89 }  // namespace cc
  90
  91 #endif  // CC_RESOURCES_PIXEL_BUFFER_RASTER_WORKER_POOL_H_