| Index: content/renderer/scheduler/renderer_scheduler_selector.h
|
| diff --git a/content/renderer/scheduler/renderer_scheduler_selector.h b/content/renderer/scheduler/renderer_scheduler_selector.h
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..a79b15a7cc13228b2b8c98fbd5c5af5d973deb61
|
| --- /dev/null
|
| +++ b/content/renderer/scheduler/renderer_scheduler_selector.h
|
| @@ -0,0 +1,69 @@
|
| +// Copyright 2014 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_RENDERER_SCHEDULER_RENDERER_SCHEDULER_POLICY_H_
|
| +#define CONTENT_RENDERER_SCHEDULER_RENDERER_SCHEDULER_POLICY_H_
|
| +
|
| +#include "base/threading/thread_checker.h"
|
| +#include "content/renderer/scheduler/task_queue_selector.h"
|
| +
|
| +namespace content {
|
| +
|
| +class RendererSchedulerSelector : public TaskQueueSelector {
|
| + public:
|
| + enum QueuePriority {
|
| + kControlPriority,
|
| + kHighPriority,
|
| + kNormalPriority,
|
| + kBestEffortPriority,
|
| + // Must be the last entry.
|
| + kQueuePriorityCount,
|
| + kFirstQueuePriority = kControlPriority,
|
| + };
|
| +
|
| + RendererSchedulerSelector();
|
| + virtual ~RendererSchedulerSelector();
|
| +
|
| + // Set the priority of |queue_index| to |set_priority|.
|
| + void SetQueuePriority(size_t queue_index, QueuePriority priority);
|
| +
|
| + // Enable the |queue_index| with a priority of |priority|. By default all
|
| + // queues are enabled with normal priority.
|
| + void EnableQueue(size_t queue_index, QueuePriority priority);
|
| +
|
| + // Disable the |queue_index|.
|
| + void DisableQueue(size_t queue_index);
|
| +
|
| + // TaskQueueSelector implementation:
|
| + virtual void RegisterWorkQueues(
|
| + const std::vector<const base::TaskQueue*>& work_queues) override;
|
| + virtual bool SelectWorkQueueToService(size_t* out_queue_index) override;
|
| +
|
| + private:
|
| + // Return true if |out_queue_index| indicates the index of the queue with
|
| + // the oldest pending task from the set of queues of |priority|, or
|
| + // false if all queues of that priority are empty.
|
| + bool ChooseOldestWithPriority(QueuePriority priority,
|
| + size_t* out_queue_index) const;
|
| +
|
| + // Returns true if |queue_index| is enabled with the given |priority|.
|
| + bool QueueEnabledWithPriority(
|
| + size_t queue_index, QueuePriority priority) const;
|
| +
|
| + size_t PrioritiesMaskFromQueueIndex(size_t queue_index) const;
|
| +
|
| + // Number of high priority tasks which can be run before a normal priority
|
| + // task should be selected to prevent starvation.
|
| + // TODO(rmcilroy): Check if this is a good value.
|
| + static const int kMaxStarvationTasks = 5;
|
| +
|
| + base::ThreadChecker main_thread_checker_;
|
| + std::vector<const base::TaskQueue*> work_queues_;
|
| + size_t queue_priorities_[kQueuePriorityCount];
|
| + int normal_queue_starvation_count_;
|
| +};
|
| +
|
| +} // namespace content
|
| +
|
| +#endif // CONTENT_RENDERER_SCHEDULER_RENDERER_SCHEDULER_POLICY_H_
|
|
|