Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_CACHE_H_ | 5 #ifndef CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_CACHE_H_ |
| 6 #define CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_CACHE_H_ | 6 #define CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_CACHE_H_ |
| 7 | 7 |
| 8 #include "base/callback.h" | 8 #include "base/callback.h" |
| 9 #include "base/files/file_path.h" | 9 #include "base/files/file_path.h" |
| 10 #include "base/memory/ref_counted.h" | 10 #include "base/memory/ref_counted.h" |
| (...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 101 | 101 |
| 102 base::WeakPtr<ServiceWorkerCache> AsWeakPtr(); | 102 base::WeakPtr<ServiceWorkerCache> AsWeakPtr(); |
| 103 | 103 |
| 104 private: | 104 private: |
| 105 friend class base::RefCounted<ServiceWorkerCache>; | 105 friend class base::RefCounted<ServiceWorkerCache>; |
| 106 friend class TestServiceWorkerCache; | 106 friend class TestServiceWorkerCache; |
| 107 | 107 |
| 108 class BlobReader; | 108 class BlobReader; |
| 109 struct KeysContext; | 109 struct KeysContext; |
| 110 struct PutContext; | 110 struct PutContext; |
| 111 | |
| 112 // The backend progresses from uninitialized, to open, to closed, and cannot | |
| 113 // reverse direction. The open step may be skipped. | |
| 114 enum BackendState { | |
| 115 BackendUninitialized, // No backend, create backend on first operation. | |
|
falken
2014/11/07 05:03:21
Style nit: chromium enums are SNAKE_CASE
jkarlin
2014/11/07 18:55:57
Thanks! Done in https://codereview.chromium.org/69
| |
| 116 BackendOpen, // Backend can be used. | |
| 117 BackendClosed // Backend cannot be used. All ops should fail. | |
| 118 }; | |
| 119 | |
| 111 typedef std::vector<disk_cache::Entry*> Entries; | 120 typedef std::vector<disk_cache::Entry*> Entries; |
| 112 | 121 |
| 113 ServiceWorkerCache( | 122 ServiceWorkerCache( |
| 114 const GURL& origin, | 123 const GURL& origin, |
| 115 const base::FilePath& path, | 124 const base::FilePath& path, |
| 116 net::URLRequestContext* request_context, | 125 net::URLRequestContext* request_context, |
| 117 const scoped_refptr<storage::QuotaManagerProxy>& quota_manager_proxy, | 126 const scoped_refptr<storage::QuotaManagerProxy>& quota_manager_proxy, |
| 118 base::WeakPtr<storage::BlobStorageContext> blob_context); | 127 base::WeakPtr<storage::BlobStorageContext> blob_context); |
| 119 | 128 |
| 120 // Operations in progress will complete after the cache is deleted but pending | 129 // Operations in progress will complete after the cache is deleted but pending |
| (...skipping 20 matching lines...) Expand all Loading... | |
| 141 const Entries::iterator& iter); | 150 const Entries::iterator& iter); |
| 142 static void KeysDidReadMetadata( | 151 static void KeysDidReadMetadata( |
| 143 scoped_ptr<KeysContext> keys_context, | 152 scoped_ptr<KeysContext> keys_context, |
| 144 const Entries::iterator& iter, | 153 const Entries::iterator& iter, |
| 145 scoped_ptr<ServiceWorkerCacheMetadata> metadata); | 154 scoped_ptr<ServiceWorkerCacheMetadata> metadata); |
| 146 | 155 |
| 147 // Loads the backend and calls the callback with the result (true for | 156 // Loads the backend and calls the callback with the result (true for |
| 148 // success). The callback will always be called. Virtual for tests. | 157 // success). The callback will always be called. Virtual for tests. |
| 149 virtual void CreateBackend(const ErrorCallback& callback); | 158 virtual void CreateBackend(const ErrorCallback& callback); |
| 150 | 159 |
| 151 void Init(const base::Closure& callback); | 160 void InitBackend(const base::Closure& callback); |
| 152 void InitDone(ErrorType error); | 161 void InitDone(ErrorType error); |
| 153 | 162 |
| 154 void IncPendingOps() { pending_ops_++; } | 163 void IncPendingOps() { pending_ops_++; } |
| 155 void DecPendingOps(); | 164 void DecPendingOps(); |
| 156 void PendingErrorCallback(const ErrorCallback& callback, ErrorType error); | 165 void PendingErrorCallback(const ErrorCallback& callback, ErrorType error); |
| 157 void PendingResponseCallback( | 166 void PendingResponseCallback( |
| 158 const ResponseCallback& callback, | 167 const ResponseCallback& callback, |
| 159 ErrorType error, | 168 ErrorType error, |
| 160 scoped_ptr<ServiceWorkerResponse> response, | 169 scoped_ptr<ServiceWorkerResponse> response, |
| 161 scoped_ptr<storage::BlobDataHandle> blob_data_handle); | 170 scoped_ptr<storage::BlobDataHandle> blob_data_handle); |
| 162 void PendingRequestsCallback(const RequestsCallback& callback, | 171 void PendingRequestsCallback(const RequestsCallback& callback, |
| 163 ErrorType error, | 172 ErrorType error, |
| 164 scoped_ptr<Requests> requests); | 173 scoped_ptr<Requests> requests); |
| 165 | 174 |
| 166 // The backend can be deleted via the Close function at any time so always | 175 // The backend can be deleted via the Close function at any time so always |
| 167 // check for its existence before use. | 176 // check for its existence before use. |
| 168 scoped_ptr<disk_cache::Backend> backend_; | 177 scoped_ptr<disk_cache::Backend> backend_; |
| 169 GURL origin_; | 178 GURL origin_; |
| 170 base::FilePath path_; | 179 base::FilePath path_; |
| 171 net::URLRequestContext* request_context_; | 180 net::URLRequestContext* request_context_; |
| 172 scoped_refptr<storage::QuotaManagerProxy> quota_manager_proxy_; | 181 scoped_refptr<storage::QuotaManagerProxy> quota_manager_proxy_; |
| 173 base::WeakPtr<storage::BlobStorageContext> blob_storage_context_; | 182 base::WeakPtr<storage::BlobStorageContext> blob_storage_context_; |
| 174 bool initialized_; | 183 BackendState backend_state_; |
| 175 std::vector<base::Closure> init_callbacks_; | 184 std::vector<base::Closure> init_callbacks_; |
| 176 | 185 |
| 177 // Whether or not to store data in disk or memory. | 186 // Whether or not to store data in disk or memory. |
| 178 bool memory_only_; | 187 bool memory_only_; |
| 179 | 188 |
| 180 // The number of started operations that have yet to complete. | 189 // The number of started operations that have yet to complete. |
| 181 // TODO(jkarlin): pending_ops_ gets double counted on lazy initialization (say | 190 // TODO(jkarlin): pending_ops_ gets double counted on lazy initialization (say |
| 182 // in ::Put). The counting still works but pending_ops_ doesn't accurately | 191 // in ::Put). The counting still works but pending_ops_ doesn't accurately |
| 183 // represent the number of operations in flight. Fix this by having the lazy | 192 // represent the number of operations in flight. Fix this by having the lazy |
| 184 // init callback call a different function than the original caller (::Put). | 193 // init callback call a different function than the original caller (::Put). |
| 185 size_t pending_ops_; | 194 size_t pending_ops_; |
| 186 base::Closure ops_complete_callback_; | 195 base::Closure ops_complete_callback_; |
| 187 | 196 |
| 188 base::WeakPtrFactory<ServiceWorkerCache> weak_ptr_factory_; | 197 base::WeakPtrFactory<ServiceWorkerCache> weak_ptr_factory_; |
| 189 | 198 |
| 190 DISALLOW_COPY_AND_ASSIGN(ServiceWorkerCache); | 199 DISALLOW_COPY_AND_ASSIGN(ServiceWorkerCache); |
| 191 }; | 200 }; |
| 192 | 201 |
| 193 } // namespace content | 202 } // namespace content |
| 194 | 203 |
| 195 #endif // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_CACHE_H_ | 204 #endif // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_CACHE_H_ |
| OLD | NEW |