Implement memory-persistent registration

content/browser/service_worker/service_worker_storage.h

Index: content/browser/service_worker/service_worker_storage.h
diff --git a/content/browser/service_worker/service_worker_storage.h b/content/browser/service_worker/service_worker_storage.h
new file mode 100644
index 0000000000000000000000000000000000000000..129824011928da1e90a91b2049f51ec612a8c32c
--- /dev/null
+++ b/content/browser/service_worker/service_worker_storage.h
@@ -0,0 +1,94 @@
+// Copyright (c) 2013 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#ifndef CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_STORAGE_H_
+#define CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_STORAGE_H_
+
+#include <map>
+
+#include "base/bind.h"
+#include "base/files/file_path.h"
+#include "base/gtest_prod_util.h"
+#include "base/memory/scoped_vector.h"
+#include "content/common/content_export.h"
+#include "url/gurl.h"
+
+namespace quota {
+class QuotaManagerProxy;
+}
+
+namespace content {
+
+class ServiceWorkerRegistration;
+class ServiceWorkerRegisterJob;
+
+// This class provides an interface to load registration data and
+// instantiate ServiceWorkerRegistration objects.
+class CONTENT_EXPORT ServiceWorkerStorage {
+ public:
+  ServiceWorkerStorage(const base::FilePath& path,
+                       quota::QuotaManagerProxy* quota_manager_proxy);
+  ~ServiceWorkerStorage();
+
+  void Shutdown();
+
+  typedef base::Callback<void(const scoped_refptr<ServiceWorkerRegistration>&)>
+      ResponseCallback;
+
+  void FindRegistrationForDocument(const GURL& document_url,
+                                   const ResponseCallback& callback);
+  void FindRegistrationForPattern(const GURL& pattern,
+                                  const ResponseCallback& callback);
+
+  void Register(const GURL& pattern,
+                const GURL& script_url,
+                const ResponseCallback& callback);
+
+  void Unregister(const GURL& pattern, const base::Closure& callback);
+
+ private:
+  friend class ServiceWorkerRegisterJob;
+  FRIEND_TEST_ALL_PREFIXES(ServiceWorkerStorageTest, RegisterMatch);
+
+  void EraseJob(ServiceWorkerRegisterJob* job);
+
+  void RegisterComplete(const ResponseCallback& callback,
+                        ServiceWorkerRegisterJob* job,
+                        ServiceWorkerRegistration* registration);
+  void UnregisterComplete(const base::Closure& callback,
+                          ServiceWorkerRegisterJob* job,
+                          ServiceWorkerRegistration* registration);
+
+  // TODO(alecflett): These are temporary internal methods mainly for
+  // exposure to tests. These should eventually call through to some
+  // sort of ServiceWorkerStorage interface which will be
+  // asynchronous.

[kinuko, 2013/11/25 08:17:10]

Not seem to be really used by tests? (Instead Job seems to be calling these)

+  scoped_refptr<ServiceWorkerRegistration> RegisterInternal(
+      const GURL& pattern,
+      const GURL& script_url);
+  void UnregisterInternal(const GURL& pattern);
+  static bool PatternMatches(const GURL& pattern, const GURL& script_url);
+
+  // Eventually the registration should be stored in leveldb, not in
+  // memory.
+  typedef std::map<GURL, scoped_refptr<ServiceWorkerRegistration> >
+      PatternToRegistrationMap;
+  typedef ScopedVector<ServiceWorkerRegisterJob> RegistrationJobList;
+
+  // currently running jobs. This is a temporary structure until we
+  // start managing overlapping registrations explicitly.
+  RegistrationJobList registration_jobs_;
+
+  // in-memory map, to eventually be replaced with persistence
+  PatternToRegistrationMap registration_by_pattern_;
+  scoped_refptr<quota::QuotaManagerProxy> quota_manager_proxy_;
+  base::FilePath path_;
+  base::WeakPtrFactory<ServiceWorkerStorage> weak_factory_;
+
+  DISALLOW_COPY_AND_ASSIGN(ServiceWorkerStorage);
+};
+
+}  // namespace content
+
+#endif  // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_STORAGE_H_