| Index: content/browser/service_worker/service_worker_cache_listener.cc
|
| diff --git a/content/browser/service_worker/service_worker_cache_listener.cc b/content/browser/service_worker/service_worker_cache_listener.cc
|
| index 4badaa86933221f07e115ca89d86ce4cd3e8e44d..4082730e73877c0388812dfb7e3fffe15ac9714e 100644
|
| --- a/content/browser/service_worker/service_worker_cache_listener.cc
|
| +++ b/content/browser/service_worker/service_worker_cache_listener.cc
|
| @@ -7,12 +7,10 @@
|
| #include "base/bind.h"
|
| #include "base/debug/trace_event.h"
|
| #include "base/strings/utf_string_conversions.h"
|
| -#include "content/browser/service_worker/service_worker_cache.h"
|
| #include "content/browser/service_worker/service_worker_cache_storage_manager.h"
|
| #include "content/browser/service_worker/service_worker_context_core.h"
|
| #include "content/browser/service_worker/service_worker_version.h"
|
| #include "content/common/service_worker/service_worker_messages.h"
|
| -#include "storage/browser/blob/blob_data_handle.h"
|
| #include "third_party/WebKit/public/platform/WebServiceWorkerCacheError.h"
|
|
|
| namespace content {
|
| @@ -34,33 +32,12 @@
|
| case ServiceWorkerCacheStorage::CACHE_STORAGE_ERROR_EXISTS:
|
| return blink::WebServiceWorkerCacheErrorExists;
|
| case ServiceWorkerCacheStorage::CACHE_STORAGE_ERROR_STORAGE:
|
| - // TODO(jkarlin): Change this to CACHE_STORAGE_ERROR_STORAGE once that's
|
| + // TODO(jkarlin): Changethis to CACHE_STORAGE_ERROR_STORAGE once that's
|
| // added.
|
| return blink::WebServiceWorkerCacheErrorNotFound;
|
| case ServiceWorkerCacheStorage::CACHE_STORAGE_ERROR_CLOSING:
|
| // TODO(jkarlin): Update this to CACHE_STORAGE_ERROR_CLOSING once that's
|
| // added.
|
| - return blink::WebServiceWorkerCacheErrorNotFound;
|
| - }
|
| - NOTREACHED();
|
| - return blink::WebServiceWorkerCacheErrorNotImplemented;
|
| -}
|
| -
|
| -// TODO(jkarlin): ServiceWorkerCache and ServiceWorkerCacheStorage should share
|
| -// an error enum type.
|
| -WebServiceWorkerCacheError CacheErrorToWebServiceWorkerCacheError(
|
| - ServiceWorkerCache::ErrorType err) {
|
| - switch (err) {
|
| - case ServiceWorkerCache::ErrorTypeOK:
|
| - NOTREACHED();
|
| - return blink::WebServiceWorkerCacheErrorNotImplemented;
|
| - case ServiceWorkerCache::ErrorTypeExists:
|
| - return blink::WebServiceWorkerCacheErrorExists;
|
| - case ServiceWorkerCache::ErrorTypeStorage:
|
| - // TODO(jkarlin): Change this to CACHE_STORAGE_ERROR_STORAGE once that's
|
| - // added.
|
| - return blink::WebServiceWorkerCacheErrorNotFound;
|
| - case ServiceWorkerCache::ErrorTypeNotFound:
|
| return blink::WebServiceWorkerCacheErrorNotFound;
|
| }
|
| NOTREACHED();
|
| @@ -178,24 +155,9 @@
|
| int cache_id,
|
| const ServiceWorkerFetchRequest& request,
|
| const ServiceWorkerCacheQueryParams& match_params) {
|
| - IDToCacheMap::iterator it = id_to_cache_map_.find(cache_id);
|
| - if (it == id_to_cache_map_.end()) {
|
| - Send(ServiceWorkerMsg_CacheMatchError(
|
| - request_id, blink::WebServiceWorkerCacheErrorNotFound));
|
| - return;
|
| - }
|
| -
|
| - scoped_refptr<ServiceWorkerCache> cache = it->second;
|
| - scoped_ptr<ServiceWorkerFetchRequest> scoped_request(
|
| - new ServiceWorkerFetchRequest(request.url,
|
| - request.method,
|
| - request.headers,
|
| - request.referrer,
|
| - request.is_reload));
|
| - cache->Match(scoped_request.Pass(),
|
| - base::Bind(&ServiceWorkerCacheListener::OnCacheMatchCallback,
|
| - weak_factory_.GetWeakPtr(),
|
| - request_id));
|
| + // TODO(gavinp,jkarlin): Implement this method.
|
| + Send(ServiceWorkerMsg_CacheMatchError(
|
| + request_id, blink::WebServiceWorkerCacheErrorNotImplemented));
|
| }
|
|
|
| void ServiceWorkerCacheListener::OnCacheMatchAll(
|
| @@ -213,77 +175,22 @@
|
| int cache_id,
|
| const ServiceWorkerFetchRequest& request,
|
| const ServiceWorkerCacheQueryParams& match_params) {
|
| - IDToCacheMap::iterator it = id_to_cache_map_.find(cache_id);
|
| - if (it == id_to_cache_map_.end()) {
|
| - Send(ServiceWorkerMsg_CacheKeysError(
|
| - request_id, blink::WebServiceWorkerCacheErrorNotFound));
|
| - return;
|
| - }
|
| -
|
| - scoped_refptr<ServiceWorkerCache> cache = it->second;
|
| -
|
| - cache->Keys(base::Bind(&ServiceWorkerCacheListener::OnCacheKeysCallback,
|
| - weak_factory_.GetWeakPtr(),
|
| - request_id));
|
| + // TODO(gavinp,jkarlin): Implement this method.
|
| + Send(ServiceWorkerMsg_CacheKeysError(
|
| + request_id, blink::WebServiceWorkerCacheErrorNotImplemented));
|
| }
|
|
|
| void ServiceWorkerCacheListener::OnCacheBatch(
|
| int request_id,
|
| int cache_id,
|
| const std::vector<ServiceWorkerBatchOperation>& operations) {
|
| - if (operations.size() != 1u) {
|
| - Send(ServiceWorkerMsg_CacheBatchError(
|
| - request_id, blink::WebServiceWorkerCacheErrorNotImplemented));
|
| - return;
|
| - }
|
| -
|
| - IDToCacheMap::iterator it = id_to_cache_map_.find(cache_id);
|
| - if (it == id_to_cache_map_.end()) {
|
| - Send(ServiceWorkerMsg_CacheBatchError(
|
| - request_id, blink::WebServiceWorkerCacheErrorNotFound));
|
| - return;
|
| - }
|
| -
|
| - const ServiceWorkerBatchOperation& operation = operations[0];
|
| -
|
| - scoped_refptr<ServiceWorkerCache> cache = it->second;
|
| - scoped_ptr<ServiceWorkerFetchRequest> scoped_request(
|
| - new ServiceWorkerFetchRequest(operation.request.url,
|
| - operation.request.method,
|
| - operation.request.headers,
|
| - operation.request.referrer,
|
| - operation.request.is_reload));
|
| -
|
| - if (operation.operation_type == SERVICE_WORKER_CACHE_OPERATION_TYPE_DELETE) {
|
| - cache->Delete(scoped_request.Pass(),
|
| - base::Bind(&ServiceWorkerCacheListener::OnCacheDeleteCallback,
|
| - weak_factory_.GetWeakPtr(),
|
| - request_id));
|
| - return;
|
| - }
|
| -
|
| - if (operation.operation_type == SERVICE_WORKER_CACHE_OPERATION_TYPE_PUT) {
|
| - scoped_ptr<ServiceWorkerResponse> scoped_response(
|
| - new ServiceWorkerResponse(operation.response.url,
|
| - operation.response.status_code,
|
| - operation.response.status_text,
|
| - operation.response.headers,
|
| - operation.response.blob_uuid));
|
| - cache->Put(scoped_request.Pass(),
|
| - scoped_response.Pass(),
|
| - base::Bind(&ServiceWorkerCacheListener::OnCachePutCallback,
|
| - weak_factory_.GetWeakPtr(),
|
| - request_id));
|
| -
|
| - return;
|
| - }
|
| -
|
| + // TODO(gavinp,jkarlin): Implement this method.
|
| Send(ServiceWorkerMsg_CacheBatchError(
|
| request_id, blink::WebServiceWorkerCacheErrorNotImplemented));
|
| }
|
|
|
| void ServiceWorkerCacheListener::OnCacheClosed(int cache_id) {
|
| - DropCacheReference(cache_id);
|
| + // TODO(gavinp,jkarlin): Implement this method.
|
| }
|
|
|
| void ServiceWorkerCacheListener::Send(const IPC::Message& message) {
|
| @@ -363,84 +270,6 @@
|
| string16s.push_back(base::UTF8ToUTF16(strings[i]));
|
| }
|
| Send(ServiceWorkerMsg_CacheStorageKeysSuccess(request_id, string16s));
|
| -}
|
| -
|
| -void ServiceWorkerCacheListener::OnCacheMatchCallback(
|
| - int request_id,
|
| - ServiceWorkerCache::ErrorType error,
|
| - scoped_ptr<ServiceWorkerResponse> response,
|
| - scoped_ptr<storage::BlobDataHandle> blob_data_handle) {
|
| - if (error != ServiceWorkerCache::ErrorTypeOK) {
|
| - Send(ServiceWorkerMsg_CacheMatchError(
|
| - request_id, CacheErrorToWebServiceWorkerCacheError(error)));
|
| - return;
|
| - }
|
| -
|
| - // TODO(jkarlin): Once there is a message acknowledging the blob handle from
|
| - // the renderer then store the blob_data_handle until the message is received.
|
| - // For now just drop it.
|
| - Send(ServiceWorkerMsg_CacheMatchSuccess(
|
| - request_id,
|
| - ServiceWorkerResponse(response->url,
|
| - response->status_code,
|
| - response->status_text,
|
| - response->headers,
|
| - "")));
|
| -}
|
| -
|
| -void ServiceWorkerCacheListener::OnCacheKeysCallback(
|
| - int request_id,
|
| - ServiceWorkerCache::ErrorType error,
|
| - scoped_ptr<ServiceWorkerCache::Requests> requests) {
|
| - if (error != ServiceWorkerCache::ErrorTypeOK) {
|
| - Send(ServiceWorkerMsg_CacheKeysError(
|
| - request_id, CacheErrorToWebServiceWorkerCacheError(error)));
|
| - return;
|
| - }
|
| -
|
| - ServiceWorkerCache::Requests out;
|
| -
|
| - for (ServiceWorkerCache::Requests::const_iterator it = requests->begin();
|
| - it != requests->end();
|
| - ++it) {
|
| - ServiceWorkerFetchRequest request(
|
| - it->url, it->method, it->headers, it->referrer, it->is_reload);
|
| - out.push_back(request);
|
| - }
|
| -
|
| - Send(ServiceWorkerMsg_CacheKeysSuccess(request_id, out));
|
| -}
|
| -
|
| -void ServiceWorkerCacheListener::OnCacheDeleteCallback(
|
| - int request_id,
|
| - ServiceWorkerCache::ErrorType error) {
|
| - if (error != ServiceWorkerCache::ErrorTypeOK) {
|
| - Send(ServiceWorkerMsg_CacheBatchError(
|
| - request_id, CacheErrorToWebServiceWorkerCacheError(error)));
|
| - return;
|
| - }
|
| -
|
| - Send(ServiceWorkerMsg_CacheBatchSuccess(
|
| - request_id, std::vector<ServiceWorkerResponse>()));
|
| -}
|
| -
|
| -void ServiceWorkerCacheListener::OnCachePutCallback(
|
| - int request_id,
|
| - ServiceWorkerCache::ErrorType error,
|
| - scoped_ptr<ServiceWorkerResponse> response,
|
| - scoped_ptr<storage::BlobDataHandle> blob_data_handle) {
|
| - if (error != ServiceWorkerCache::ErrorTypeOK) {
|
| - Send(ServiceWorkerMsg_CacheBatchError(
|
| - request_id, CacheErrorToWebServiceWorkerCacheError(error)));
|
| - return;
|
| - }
|
| -
|
| - // TODO(jkarlin): Once there is a message acknowledging the blob handle from
|
| - // the renderer then store the blob_data_handle until the message is received.
|
| - // For now just drop it.
|
| - std::vector<ServiceWorkerResponse> responses;
|
| - responses.push_back(*response);
|
| - Send(ServiceWorkerMsg_CacheBatchSuccess(request_id, responses));
|
| }
|
|
|
| ServiceWorkerCacheListener::CacheID
|
|
|