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

Unified Diff: cc/base/worker_pool.cc

Issue 12519006: cc:: Add RenderingStatsInstrumentation to manage collection of RenderingStats (Closed) Base URL: http://git.chromium.org/chromium/src.git@master
Patch Set: Updated all tests Created 7 years, 9 months 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « cc/base/worker_pool.h ('k') | cc/cc.gyp » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: cc/base/worker_pool.cc
diff --git a/cc/base/worker_pool.cc b/cc/base/worker_pool.cc
index caa3159a78bac1ef12dd3a1a0172d7778f33fc32..25596d40718ff747e893d34fe1001a5dc6772939 100644
--- a/cc/base/worker_pool.cc
+++ b/cc/base/worker_pool.cc
@@ -9,7 +9,6 @@
#include "base/stringprintf.h"
#include "base/synchronization/condition_variable.h"
#include "base/threading/simple_thread.h"
-#include "cc/debug/rendering_stats.h"
#if defined(OS_ANDROID)
// TODO(epenner): Move thread priorities to base. (crbug.com/170549)
@@ -29,13 +28,12 @@ class WorkerPoolTaskImpl : public internal::WorkerPoolTask {
virtual bool IsCheap() OVERRIDE { return false; }
- virtual void Run(RenderingStats* rendering_stats) OVERRIDE {
- task_.Run(rendering_stats);
+ virtual void Run() OVERRIDE {
+ task_.Run();
}
- virtual void RunOnThread(
- RenderingStats* rendering_stats, unsigned thread_index) OVERRIDE {
- task_.Run(rendering_stats);
+ virtual void RunOnThread(unsigned thread_index) OVERRIDE {
+ task_.Run();
}
private:
@@ -71,10 +69,6 @@ class WorkerPool::Inner : public base::DelegateSimpleThread::Delegate {
void Shutdown();
- void SetRecordRenderingStats(bool record_rendering_stats);
-
- void GetRenderingStats(RenderingStats* stats);
-
void PostTask(scoped_ptr<internal::WorkerPoolTask> task, bool signal_workers);
// Appends all completed tasks to worker pool's completed tasks queue
@@ -149,8 +143,6 @@ class WorkerPool::Inner : public base::DelegateSimpleThread::Delegate {
TaskDeque pending_tasks_;
TaskDeque completed_tasks_;
- scoped_ptr<RenderingStats> rendering_stats_;
-
ScopedPtrDeque<base::DelegateSimpleThread> workers_;
DISALLOW_COPY_AND_ASSIGN(Inner);
@@ -220,22 +212,6 @@ void WorkerPool::Inner::Shutdown() {
}
}
-void WorkerPool::Inner::SetRecordRenderingStats(bool record_rendering_stats) {
- base::AutoLock lock(lock_);
-
- if (record_rendering_stats)
- rendering_stats_.reset(new RenderingStats);
- else
- rendering_stats_.reset();
-}
-
-void WorkerPool::Inner::GetRenderingStats(RenderingStats* stats) {
- base::AutoLock lock(lock_);
-
- if (rendering_stats_)
- stats->Add(*rendering_stats_);
-}
-
void WorkerPool::Inner::PostTask(scoped_ptr<internal::WorkerPoolTask> task,
bool signal_workers) {
base::AutoLock lock(lock_);
@@ -279,18 +255,13 @@ bool WorkerPool::Inner::RunCheapTasksUntilTimeLimit(
break;
}
- scoped_ptr<RenderingStats> rendering_stats;
- // Collect rendering stats if |rendering_stats_| is set.
- if (rendering_stats_)
- rendering_stats = make_scoped_ptr(new RenderingStats);
-
// Increment |running_task_count_| before starting to run task.
running_task_count_++;
{
base::AutoUnlock unlock(lock_);
- task->Run(rendering_stats.get());
+ task->Run();
// Append tasks directly to worker pool's completed tasks queue.
worker_pool_on_origin_thread_->completed_tasks_.push_back(task.Pass());
@@ -298,10 +269,6 @@ bool WorkerPool::Inner::RunCheapTasksUntilTimeLimit(
worker_pool_on_origin_thread_->OnTaskCompleted();
}
- // Add rendering stat results to |rendering_stats_|.
- if (rendering_stats && rendering_stats_)
- rendering_stats_->Add(*rendering_stats);
-
// Decrement |running_task_count_| now that we are done running task.
running_task_count_--;
}
@@ -405,11 +372,6 @@ void WorkerPool::Inner::Run() {
// Get next task.
scoped_ptr<internal::WorkerPoolTask> task = pending_tasks_.take_front();
- scoped_ptr<RenderingStats> rendering_stats;
- // Collect rendering stats if |rendering_stats_| is set.
- if (rendering_stats_)
- rendering_stats = make_scoped_ptr(new RenderingStats);
-
// Increment |running_task_count_| before starting to run task.
running_task_count_++;
@@ -420,15 +382,11 @@ void WorkerPool::Inner::Run() {
{
base::AutoUnlock unlock(lock_);
- task->RunOnThread(rendering_stats.get(), thread_index);
+ task->RunOnThread(thread_index);
}
completed_tasks_.push_back(task.Pass());
- // Add rendering stat results to |rendering_stats_|.
- if (rendering_stats && rendering_stats_)
- rendering_stats_->Add(*rendering_stats);
-
// Decrement |running_task_count_| now that we are done running task.
running_task_count_--;
@@ -492,14 +450,6 @@ void WorkerPool::SetRunCheapTasksTimeLimit(
ScheduleRunCheapTasks();
}
-void WorkerPool::SetRecordRenderingStats(bool record_rendering_stats) {
- inner_->SetRecordRenderingStats(record_rendering_stats);
-}
-
-void WorkerPool::GetRenderingStats(RenderingStats* stats) {
- inner_->GetRenderingStats(stats);
-}
-
void WorkerPool::OnIdle() {
TRACE_EVENT0("cc", "WorkerPool::OnIdle");
« no previous file with comments | « cc/base/worker_pool.h ('k') | cc/cc.gyp » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698