Chromium Code Reviews| OLD | NEW |
|---|---|
| (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 #include "content/public/browser/power_profiler_service.h" | |
| 6 | |
| 7 #include "base/bind.h" | |
| 8 #include "base/message_loop/message_loop.h" | |
| 9 #include "base/threading/sequenced_worker_pool.h" | |
| 10 #include "content/public/browser/browser_thread.h" | |
| 11 | |
| 12 namespace content { | |
| 13 | |
| 14 PowerProfilerService::PowerProfilerService() | |
| 15 : status_(UNINITIALIZED) | |
| 16 , data_provider_(PowerDataProviderFactory::Create()) { | |
| 17 if (data_provider_.get()) { | |
| 18 status_ = INITIALIZED; | |
| 19 InitializeDelays(); | |
| 20 task_runner_ = BrowserThread::GetBlockingPool()->GetSequencedTaskRunner( | |
| 21 BrowserThread::GetBlockingPool()->GetSequenceToken()); | |
| 22 } | |
| 23 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 24 } | |
| 25 | |
| 26 bool PowerProfilerService::IsAvailable() { | |
| 27 return status_ != UNINITIALIZED; | |
| 28 } | |
| 29 | |
| 30 void PowerProfilerService::InitializeDelays() { | |
| 31 delays_[PowerProfilerObserver::LOW] = base::TimeDelta::FromMilliseconds(4000); | |
| 32 delays_[PowerProfilerObserver::NORMAL] | |
| 33 = base::TimeDelta::FromMilliseconds(200); | |
| 34 delays_[PowerProfilerObserver::HIGH] = base::TimeDelta::FromMilliseconds(50); | |
| 35 } | |
| 36 | |
| 37 PowerProfilerService* PowerProfilerService::GetInstance() { | |
| 38 return Singleton<PowerProfilerService>::get(); | |
| 39 } | |
| 40 | |
| 41 bool PowerProfilerService::AddObserver(PowerProfilerObserver* obs) { | |
|
qsr
2014/01/23 12:50:06
I don't think you need a return value here. If som
Pan
2014/01/25 09:35:53
Done.
| |
| 42 if (UNINITIALIZED == status_) | |
| 43 return false; | |
| 44 | |
| 45 observers_.AddObserver(obs); | |
| 46 UpdateResolution(); | |
| 47 if (PROFILING != status_) | |
| 48 Start(); | |
| 49 | |
| 50 return true; | |
| 51 } | |
| 52 | |
| 53 void PowerProfilerService::RemoveObserver(PowerProfilerObserver* obs) { | |
| 54 observers_.RemoveObserver(obs); | |
| 55 UpdateResolution(); | |
| 56 if (!observers_.might_have_observers()) | |
| 57 Stop(); | |
| 58 } | |
| 59 | |
| 60 void PowerProfilerService::UpdateResolution() { | |
| 61 if (UNINITIALIZED == status_) | |
| 62 return; | |
| 63 | |
| 64 PowerProfilerObserver::Resolution resolution = PowerProfilerObserver::LOW; | |
| 65 FOR_EACH_OBSERVER(PowerProfilerObserver, observers_, | |
| 66 GetHigherResolution(resolution)); | |
|
qsr
2014/01/23 12:50:06
I don't really like that each observer needs to im
Pan
2014/01/25 09:35:53
Done.
| |
| 67 | |
| 68 // if delay_ will be reset, reschedule the timer immediately | |
| 69 if (delay_ != delays_[resolution]) { | |
| 70 delay_ = delays_[resolution]; | |
| 71 | |
| 72 if (query_power_timer_.IsRunning()) | |
|
qsr
2014/01/23 12:50:06
You might want to check on your status, instead of
Pan
2014/01/25 09:35:53
Done.
| |
| 73 query_power_timer_.Start(FROM_HERE, | |
| 74 delay_, this, &PowerProfilerService::OnTimer); | |
| 75 } | |
| 76 } | |
| 77 | |
| 78 void PowerProfilerService::Start() { | |
| 79 DCHECK (!query_power_timer_.IsRunning()); | |
|
qsr
2014/01/23 12:50:06
Maybe also check for your status.
Pan
2014/01/25 09:35:53
Done.
| |
| 80 status_ = PROFILING; | |
| 81 | |
| 82 // send out power events immediately. | |
| 83 task_runner_->PostTask( | |
| 84 FROM_HERE, | |
| 85 base::Bind(&PowerProfilerService::ProcessData, base::Unretained(this))); | |
| 86 | |
| 87 query_power_timer_.Start(FROM_HERE, | |
| 88 delay_, this, &PowerProfilerService::OnTimer); | |
| 89 } | |
| 90 | |
| 91 void PowerProfilerService::Stop() { | |
| 92 // stop timer, set status to INITIALIZED | |
| 93 if (PROFILING == status_) { | |
|
qsr
2014/01/23 12:50:06
Why is that a test instead of a DCHECK? Are you ex
Pan
2014/01/25 09:35:53
Done.
| |
| 94 query_power_timer_.Stop(); | |
| 95 status_ = INITIALIZED; | |
| 96 } | |
| 97 } | |
| 98 | |
| 99 void PowerProfilerService::OnTimer() { | |
| 100 task_runner_->PostTask( | |
| 101 FROM_HERE, | |
| 102 base::Bind(&PowerProfilerService::ProcessData, base::Unretained(this))); | |
| 103 } | |
| 104 | |
| 105 void PowerProfilerService::Notify(const PowerEvent& event) { | |
| 106 FOR_EACH_OBSERVER(PowerProfilerObserver, observers_, OnPowerEvent(event)); | |
| 107 } | |
| 108 | |
| 109 void PowerProfilerService::ProcessData() { | |
|
qsr
2014/01/23 12:50:06
you could DCHECK that you are on your task_runner
Pan
2014/01/25 09:35:53
Done.
| |
| 110 if (PROFILING != status_) | |
| 111 return; | |
| 112 | |
| 113 // Get Data and Notify | |
| 114 PowerEvent event; | |
| 115 if(data_provider_->GetData(&event)) | |
| 116 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, base::Bind( | |
| 117 &PowerProfilerService::Notify, base::Unretained(this), event)); | |
| 118 } | |
| 119 | |
| 120 } // namespace content | |
| OLD | NEW |