| Index: content/browser/service_worker/service_worker_job_coordinator.cc
|
| diff --git a/content/browser/service_worker/service_worker_job_coordinator.cc b/content/browser/service_worker/service_worker_job_coordinator.cc
|
| index f72187e1bdfd2520816a660e6f3020f706910321..58d7e442a585155ce22dd3cd1daa2673958ea6ab 100644
|
| --- a/content/browser/service_worker/service_worker_job_coordinator.cc
|
| +++ b/content/browser/service_worker/service_worker_job_coordinator.cc
|
| @@ -5,7 +5,6 @@
|
| #include "content/browser/service_worker/service_worker_job_coordinator.h"
|
|
|
| #include "base/stl_util.h"
|
| -#include "content/browser/service_worker/embedded_worker_registry.h"
|
| #include "content/browser/service_worker/service_worker_registration.h"
|
|
|
| namespace content {
|
| @@ -13,14 +12,11 @@
|
| ServiceWorkerJobCoordinator::JobQueue::JobQueue() {}
|
|
|
| ServiceWorkerJobCoordinator::JobQueue::~JobQueue() {
|
| - DCHECK(jobs_.empty()) << "Destroying JobQueue with " << jobs_.size()
|
| - << " unfinished jobs";
|
| STLDeleteElements(&jobs_);
|
| }
|
|
|
| void ServiceWorkerJobCoordinator::JobQueue::Push(
|
| scoped_ptr<ServiceWorkerRegisterJob> job,
|
| - int source_process_id,
|
| const ServiceWorkerRegisterJob::RegistrationCallback& callback) {
|
| if (jobs_.empty()) {
|
| job->Start();
|
| @@ -28,10 +24,9 @@
|
| } else if (!job->Equals(jobs_.back())) {
|
| jobs_.push_back(job.release());
|
| }
|
| - // Note we are releasing 'job' here.
|
|
|
| DCHECK(!jobs_.empty());
|
| - jobs_.back()->AddCallback(callback, source_process_id);
|
| + jobs_.back()->AddCallback(callback);
|
| }
|
|
|
| void ServiceWorkerJobCoordinator::JobQueue::Pop(ServiceWorkerRegisterJob* job) {
|
| @@ -43,47 +38,36 @@
|
| }
|
|
|
| ServiceWorkerJobCoordinator::ServiceWorkerJobCoordinator(
|
| - ServiceWorkerStorage* storage,
|
| - EmbeddedWorkerRegistry* worker_registry)
|
| - : storage_(storage),
|
| - worker_registry_(worker_registry),
|
| - weak_factory_(this) {}
|
| + ServiceWorkerStorage* storage)
|
| + : storage_(storage), weak_factory_(this) {}
|
|
|
| -ServiceWorkerJobCoordinator::~ServiceWorkerJobCoordinator() {
|
| - DCHECK(jobs_.empty()) << "Destroying ServiceWorkerJobCoordinator with "
|
| - << jobs_.size() << " job queues";
|
| -}
|
| +ServiceWorkerJobCoordinator::~ServiceWorkerJobCoordinator() {}
|
|
|
| void ServiceWorkerJobCoordinator::Register(
|
| const GURL& pattern,
|
| const GURL& script_url,
|
| - int source_process_id,
|
| const ServiceWorkerRegisterJob::RegistrationCallback& callback) {
|
| scoped_ptr<ServiceWorkerRegisterJob> job = make_scoped_ptr(
|
| new ServiceWorkerRegisterJob(storage_,
|
| - worker_registry_,
|
| this,
|
| pattern,
|
| script_url,
|
| ServiceWorkerRegisterJob::REGISTER));
|
| - jobs_[pattern].Push(job.Pass(), source_process_id, callback);
|
| + jobs_[pattern].Push(job.Pass(), callback);
|
| }
|
|
|
| void ServiceWorkerJobCoordinator::Unregister(
|
| const GURL& pattern,
|
| - int source_process_id,
|
| const ServiceWorkerRegisterJob::UnregistrationCallback& callback) {
|
|
|
| scoped_ptr<ServiceWorkerRegisterJob> job = make_scoped_ptr(
|
| new ServiceWorkerRegisterJob(storage_,
|
| - worker_registry_,
|
| this,
|
| pattern,
|
| GURL(),
|
| ServiceWorkerRegisterJob::UNREGISTER));
|
| jobs_[pattern]
|
| .Push(job.Pass(),
|
| - source_process_id,
|
| base::Bind(&ServiceWorkerJobCoordinator::UnregisterComplete,
|
| weak_factory_.GetWeakPtr(),
|
| callback));
|
|
|