Chromium Code Reviews| Index: chrome/browser/debugger/devtools_sanity_unittest.cc |
| =================================================================== |
| --- chrome/browser/debugger/devtools_sanity_unittest.cc (revision 119868) |
| +++ chrome/browser/debugger/devtools_sanity_unittest.cc (working copy) |
| @@ -24,8 +24,6 @@ |
| #include "chrome/test/base/in_process_browser_test.h" |
| #include "chrome/test/base/ui_test_utils.h" |
| #include "content/browser/renderer_host/render_view_host.h" |
| -#include "content/browser/worker_host/worker_process_host.h" |
| -#include "content/public/browser/browser_child_process_host_iterator.h" |
| #include "content/public/browser/child_process_data.h" |
| #include "content/public/browser/content_browser_client.h" |
| #include "content/public/browser/devtools_agent_host_registry.h" |
| @@ -292,21 +290,17 @@ |
| virtual ~WorkerCreationObserver() {} |
| virtual void WorkerCreated ( |
| - WorkerProcessHost* process, |
| - const WorkerProcessHost::WorkerInstance& instance) OVERRIDE { |
| - worker_data_->worker_process_id = process->GetData().id; |
| - worker_data_->worker_route_id = instance.worker_route_id(); |
| + const GURL& url, |
| + const string16& name, |
| + int process_id, |
| + int route_id) OVERRIDE { |
| + worker_data_->worker_process_id = process_id; |
| + worker_data_->worker_route_id = route_id; |
| WorkerService::GetInstance()->RemoveObserver(this); |
| BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, |
| MessageLoop::QuitClosure()); |
| delete this; |
| } |
| - virtual void WorkerDestroyed( |
| - WorkerProcessHost*, |
| - int worker_route_id) OVERRIDE {} |
| - virtual void WorkerContextStarted( |
| - WorkerProcessHost*, |
| - int worker_route_id) OVERRIDE {} |
| scoped_refptr<WorkerData> worker_data_; |
| }; |
| @@ -319,22 +313,14 @@ |
| private: |
| virtual ~WorkerTerminationObserver() {} |
| - virtual void WorkerCreated ( |
| - WorkerProcessHost* process, |
| - const WorkerProcessHost::WorkerInstance& instance) OVERRIDE {} |
| - virtual void WorkerDestroyed( |
| - WorkerProcessHost* process, |
| - int worker_route_id) OVERRIDE { |
| - ASSERT_EQ(worker_data_->worker_process_id, process->GetData().id); |
| - ASSERT_EQ(worker_data_->worker_route_id, worker_route_id); |
| + virtual void WorkerDestroyed(int process_id, int route_id) OVERRIDE { |
| + ASSERT_EQ(worker_data_->worker_process_id, process_id); |
| + ASSERT_EQ(worker_data_->worker_route_id, route_id); |
| WorkerService::GetInstance()->RemoveObserver(this); |
| BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, |
| MessageLoop::QuitClosure()); |
| delete this; |
| } |
| - virtual void WorkerContextStarted( |
| - WorkerProcessHost*, |
| - int worker_route_id) OVERRIDE {} |
| scoped_refptr<WorkerData> worker_data_; |
| }; |
| @@ -349,15 +335,12 @@ |
| CloseDevToolsWindow(); |
| } |
| - static void TerminateWorkerOnIOThread( |
| - scoped_refptr<WorkerData> worker_data) { |
| - for (WorkerProcessHostIterator iter; !iter.Done(); ++iter) { |
| - if (iter.GetData().id == worker_data->worker_process_id) { |
| - iter->TerminateWorker(worker_data->worker_route_id); |
| - WorkerService::GetInstance()->AddObserver( |
| - new WorkerTerminationObserver(worker_data)); |
| - return; |
| - } |
| + static void TerminateWorkerOnIOThread(scoped_refptr<WorkerData> worker_data) { |
| + if (WorkerService::GetInstance()->TerminateWorker( |
| + worker_data->worker_process_id, worker_data->worker_route_id)) { |
| + WorkerService::GetInstance()->AddObserver( |
| + new WorkerTerminationObserver(worker_data)); |
| + return; |
| } |
| FAIL() << "Failed to terminate worker.\n"; |
| } |
| @@ -371,17 +354,13 @@ |
| static void WaitForFirstSharedWorkerOnIOThread( |
| scoped_refptr<WorkerData> worker_data) { |
| - for (WorkerProcessHostIterator iter; !iter.Done(); ++iter) { |
| - const WorkerProcessHost::Instances& instances = iter->instances(); |
| - for (WorkerProcessHost::Instances::const_iterator i = instances.begin(); |
| - i != instances.end(); ++i) { |
| - |
| - worker_data->worker_process_id = iter.GetData().id; |
| - worker_data->worker_route_id = i->worker_route_id(); |
| - BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, |
| - MessageLoop::QuitClosure()); |
| - return; |
| - } |
| + std::vector<WorkerService::WorkerInfo> worker_info = |
| + WorkerService::GetInstance()->GetWorkers(); |
| + for (size_t i = 0; i < worker_info.size(); ++i) { |
| + worker_data->worker_process_id = worker_info[i].process_id; |
| + worker_data->worker_route_id = worker_info[i].route_id; |
| + BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, |
| + MessageLoop::QuitClosure()); |
|
Andrew T Wilson (Slow)
2012/02/01 05:51:37
The original code had a return statement in the lo
jam
2012/02/01 16:53:53
oops, thanks. took out loop
|
| } |
| WorkerService::GetInstance()->AddObserver( |