EmbeddedWorker, browser side code

content/browser/service_worker/service_worker_version.cc

Index: content/browser/service_worker/service_worker_version.cc
diff --git a/content/browser/service_worker/service_worker_version.cc b/content/browser/service_worker/service_worker_version.cc
index fa3ad3d6bb0b513e35ca05535ff08467cc999113..a40f23161bbabbd6b7741f9f49fc51f0c5793864 100644
--- a/content/browser/service_worker/service_worker_version.cc
+++ b/content/browser/service_worker/service_worker_version.cc
@@ -4,19 +4,55 @@
 
 #include "content/browser/service_worker/service_worker_version.h"
 
+#include "base/stl_util.h"
+#include "content/browser/service_worker/embedded_worker_instance.h"
+#include "content/browser/service_worker/embedded_worker_registry.h"
+#include "content/browser/service_worker/service_worker_context_core.h"
 #include "content/browser/service_worker/service_worker_registration.h"
 
 namespace content {
 
 ServiceWorkerVersion::ServiceWorkerVersion(
-    ServiceWorkerRegistration* registration)
-    : is_shutdown_(false), registration_(registration) {}
+    ServiceWorkerRegistration* registration,
+    EmbeddedWorkerRegistry* worker_registry,
+    int version_id)
+    : version_id_(version_id),
+      is_shutdown_(false),
+      registration_(registration) {
+  if (worker_registry)
+    embedded_worker_ = worker_registry->CreateWorker();
+}
 
-ServiceWorkerVersion::~ServiceWorkerVersion() { DCHECK(is_shutdown_); }

[alecflett, 2013/12/05 05:18:42]

I've been 'git cl format'ing my CL's before review/landing, which is how some of
this stuff ends up on one line. I am intending to keep doing that (I can't be
bothered with formatting issues :)) so that may result in some churn on these
lines.

[kinuko, 2013/12/09 14:07:42]

Ok, reverted.

+ServiceWorkerVersion::~ServiceWorkerVersion() {
+  DCHECK(is_shutdown_);
+}
 
 void ServiceWorkerVersion::Shutdown() {
   is_shutdown_ = true;
   registration_ = NULL;
+  embedded_worker_.reset();
+}
+
+void ServiceWorkerVersion::StartWorker() {
+  DCHECK(!is_shutdown_);
+  DCHECK(registration_);
+  embedded_worker_->Start(version_id_, registration_->script_url());
+}
+
+void ServiceWorkerVersion::StopWorker() {
+  DCHECK(!is_shutdown_);
+  embedded_worker_->Stop();
+}
+
+void ServiceWorkerVersion::OnAssociateProvider(
+    ServiceWorkerProviderHost* provider_host) {
+  DCHECK(!is_shutdown_);
+  embedded_worker_->AddProcessReference(provider_host->process_id());
+}
+
+void ServiceWorkerVersion::OnUnassociateProvider(
+    ServiceWorkerProviderHost* provider_host) {
+  embedded_worker_->ReleaseProcessReference(provider_host->process_id());
 }
 
 }  // namespace content