Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1442)

Unified Diff: content/renderer/cache_storage/cache_storage_dispatcher.cc

Issue 1039763002: Cache Storage: Move files to content/*/cache_storage, rename classes (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: GN fix Created 5 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: content/renderer/cache_storage/cache_storage_dispatcher.cc
diff --git a/content/renderer/service_worker/service_worker_cache_storage_dispatcher.cc b/content/renderer/cache_storage/cache_storage_dispatcher.cc
similarity index 73%
rename from content/renderer/service_worker/service_worker_cache_storage_dispatcher.cc
rename to content/renderer/cache_storage/cache_storage_dispatcher.cc
index c7466cbaf7ae2faa3bcb9d5954d70d86f73f43f3..042fca99d1488d8aff1cebc4143d5b761c54e022 100644
--- a/content/renderer/service_worker/service_worker_cache_storage_dispatcher.cc
+++ b/content/renderer/cache_storage/cache_storage_dispatcher.cc
@@ -2,7 +2,7 @@
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
-#include "content/renderer/service_worker/service_worker_cache_storage_dispatcher.h"
+#include "content/renderer/cache_storage/cache_storage_dispatcher.h"
#include <map>
#include <string>
@@ -14,7 +14,7 @@
#include "base/strings/utf_string_conversions.h"
#include "base/threading/thread_local.h"
#include "content/child/thread_safe_sender.h"
-#include "content/common/service_worker/cache_storage_messages.h"
+#include "content/common/cache_storage/cache_storage_messages.h"
#include "content/public/common/referrer.h"
#include "content/public/renderer/render_thread.h"
#include "content/renderer/service_worker/service_worker_type_util.h"
@@ -30,14 +30,13 @@ using blink::WebServiceWorkerCacheStorage;
using blink::WebServiceWorkerCacheError;
using blink::WebServiceWorkerRequest;
-static base::LazyInstance<
- base::ThreadLocalPointer<ServiceWorkerCacheStorageDispatcher>>::Leaky
- g_cache_storage_dispatcher_tls = LAZY_INSTANCE_INITIALIZER;
+static base::LazyInstance<base::ThreadLocalPointer<CacheStorageDispatcher>>::
+ Leaky g_cache_storage_dispatcher_tls = LAZY_INSTANCE_INITIALIZER;
namespace {
-ServiceWorkerCacheStorageDispatcher* const kHasBeenDeleted =
- reinterpret_cast<ServiceWorkerCacheStorageDispatcher*>(0x1);
+CacheStorageDispatcher* const kHasBeenDeleted =
+ reinterpret_cast<CacheStorageDispatcher*>(0x1);
ServiceWorkerFetchRequest FetchRequestFromWebRequest(
const blink::WebServiceWorkerRequest& web_request) {
@@ -56,7 +55,7 @@ void PopulateWebRequestFromFetchRequest(
web_request->setURL(request.url);
web_request->setMethod(base::ASCIIToUTF16(request.method));
for (ServiceWorkerHeaderMap::const_iterator i = request.headers.begin(),
- end = request.headers.end();
+ end = request.headers.end();
i != end; ++i) {
web_request->setHeader(base::ASCIIToUTF16(i->first),
base::ASCIIToUTF16(i->second));
@@ -68,8 +67,8 @@ void PopulateWebRequestFromFetchRequest(
blink::WebVector<blink::WebServiceWorkerRequest> WebRequestsFromRequests(
const std::vector<ServiceWorkerFetchRequest>& requests) {
- blink::WebVector<blink::WebServiceWorkerRequest>
- web_requests(requests.size());
+ blink::WebVector<blink::WebServiceWorkerRequest> web_requests(
+ requests.size());
for (size_t i = 0; i < requests.size(); ++i)
PopulateWebRequestFromFetchRequest(requests[i], &(web_requests[i]));
return web_requests;
@@ -81,19 +80,17 @@ ServiceWorkerResponse ResponseFromWebResponse(
GetServiceWorkerHeaderMapFromWebResponse(web_response, &headers);
// We don't support streaming for cache.
DCHECK(web_response.streamURL().isEmpty());
- return ServiceWorkerResponse(web_response.url(),
- web_response.status(),
+ return ServiceWorkerResponse(web_response.url(), web_response.status(),
base::UTF16ToASCII(web_response.statusText()),
- web_response.responseType(),
- headers,
+ web_response.responseType(), headers,
base::UTF16ToASCII(web_response.blobUUID()),
web_response.blobSize(),
web_response.streamURL());
}
-ServiceWorkerCacheQueryParams QueryParamsFromWebQueryParams(
+CacheStorageCacheQueryParams QueryParamsFromWebQueryParams(
const blink::WebServiceWorkerCache::QueryParams& web_query_params) {
- ServiceWorkerCacheQueryParams query_params;
+ CacheStorageCacheQueryParams query_params;
query_params.ignore_search = web_query_params.ignoreSearch;
query_params.ignore_method = web_query_params.ignoreMethod;
query_params.ignore_vary = web_query_params.ignoreVary;
@@ -101,21 +98,21 @@ ServiceWorkerCacheQueryParams QueryParamsFromWebQueryParams(
return query_params;
}
-ServiceWorkerCacheOperationType CacheOperationTypeFromWebCacheOperationType(
+CacheStorageCacheOperationType CacheOperationTypeFromWebCacheOperationType(
blink::WebServiceWorkerCache::OperationType operation_type) {
switch (operation_type) {
case blink::WebServiceWorkerCache::OperationTypePut:
- return SERVICE_WORKER_CACHE_OPERATION_TYPE_PUT;
+ return CACHE_STORAGE_CACHE_OPERATION_TYPE_PUT;
case blink::WebServiceWorkerCache::OperationTypeDelete:
- return SERVICE_WORKER_CACHE_OPERATION_TYPE_DELETE;
+ return CACHE_STORAGE_CACHE_OPERATION_TYPE_DELETE;
default:
- return SERVICE_WORKER_CACHE_OPERATION_TYPE_UNDEFINED;
+ return CACHE_STORAGE_CACHE_OPERATION_TYPE_UNDEFINED;
}
}
-ServiceWorkerBatchOperation BatchOperationFromWebBatchOperation(
+CacheStorageBatchOperation BatchOperationFromWebBatchOperation(
const blink::WebServiceWorkerCache::BatchOperation& web_operation) {
- ServiceWorkerBatchOperation operation;
+ CacheStorageBatchOperation operation;
operation.operation_type =
CacheOperationTypeFromWebCacheOperationType(web_operation.operationType);
operation.request = FetchRequestFromWebRequest(web_operation.request);
@@ -125,7 +122,7 @@ ServiceWorkerBatchOperation BatchOperationFromWebBatchOperation(
return operation;
}
-template<typename T>
+template <typename T>
void ClearCallbacksMapWithErrors(T* callbacks_map) {
typename T::iterator iter(callbacks_map);
while (!iter.IsAtEnd()) {
@@ -143,13 +140,10 @@ void ClearCallbacksMapWithErrors(T* callbacks_map) {
// WebServiceWorkerCache API. Most of its methods delegate directly to the
// ServiceWorkerStorage object, which is able to assign unique IDs as well
// as have a lifetime longer than the requests.
-class ServiceWorkerCacheStorageDispatcher::WebCache
- : public blink::WebServiceWorkerCache {
+class CacheStorageDispatcher::WebCache : public blink::WebServiceWorkerCache {
public:
- WebCache(base::WeakPtr<ServiceWorkerCacheStorageDispatcher> dispatcher,
- int cache_id)
- : dispatcher_(dispatcher),
- cache_id_(cache_id) {}
+ WebCache(base::WeakPtr<CacheStorageDispatcher> dispatcher, int cache_id)
+ : dispatcher_(dispatcher), cache_id_(cache_id) {}
virtual ~WebCache() {
if (dispatcher_)
@@ -190,17 +184,17 @@ class ServiceWorkerCacheStorageDispatcher::WebCache
}
private:
- const base::WeakPtr<ServiceWorkerCacheStorageDispatcher> dispatcher_;
+ const base::WeakPtr<CacheStorageDispatcher> dispatcher_;
const int cache_id_;
};
-ServiceWorkerCacheStorageDispatcher::ServiceWorkerCacheStorageDispatcher(
+CacheStorageDispatcher::CacheStorageDispatcher(
ThreadSafeSender* thread_safe_sender)
: thread_safe_sender_(thread_safe_sender), weak_factory_(this) {
g_cache_storage_dispatcher_tls.Pointer()->Set(this);
}
-ServiceWorkerCacheStorageDispatcher::~ServiceWorkerCacheStorageDispatcher() {
+CacheStorageDispatcher::~CacheStorageDispatcher() {
ClearCallbacksMapWithErrors(&has_callbacks_);
ClearCallbacksMapWithErrors(&open_callbacks_);
ClearCallbacksMapWithErrors(&delete_callbacks_);
@@ -215,80 +209,73 @@ ServiceWorkerCacheStorageDispatcher::~ServiceWorkerCacheStorageDispatcher() {
g_cache_storage_dispatcher_tls.Pointer()->Set(kHasBeenDeleted);
}
-ServiceWorkerCacheStorageDispatcher*
-ServiceWorkerCacheStorageDispatcher::ThreadSpecificInstance(
+CacheStorageDispatcher* CacheStorageDispatcher::ThreadSpecificInstance(
ThreadSafeSender* thread_safe_sender) {
if (g_cache_storage_dispatcher_tls.Pointer()->Get() == kHasBeenDeleted) {
- NOTREACHED() << "Re-instantiating TLS ServiceWorkerCacheStorageDispatcher.";
+ NOTREACHED() << "Re-instantiating TLS CacheStorageDispatcher.";
g_cache_storage_dispatcher_tls.Pointer()->Set(NULL);
}
if (g_cache_storage_dispatcher_tls.Pointer()->Get())
return g_cache_storage_dispatcher_tls.Pointer()->Get();
- ServiceWorkerCacheStorageDispatcher* dispatcher =
- new ServiceWorkerCacheStorageDispatcher(thread_safe_sender);
+ CacheStorageDispatcher* dispatcher =
+ new CacheStorageDispatcher(thread_safe_sender);
if (WorkerTaskRunner::Instance()->CurrentWorkerId())
WorkerTaskRunner::Instance()->AddStopObserver(dispatcher);
return dispatcher;
}
-void ServiceWorkerCacheStorageDispatcher::OnWorkerRunLoopStopped() {
+void CacheStorageDispatcher::OnWorkerRunLoopStopped() {
delete this;
}
-bool ServiceWorkerCacheStorageDispatcher::Send(IPC::Message* msg) {
+bool CacheStorageDispatcher::Send(IPC::Message* msg) {
return thread_safe_sender_->Send(msg);
}
-bool ServiceWorkerCacheStorageDispatcher::OnMessageReceived(
- const IPC::Message& message) {
+bool CacheStorageDispatcher::OnMessageReceived(const IPC::Message& message) {
bool handled = true;
- IPC_BEGIN_MESSAGE_MAP(ServiceWorkerCacheStorageDispatcher, message)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheStorageHasSuccess,
+ IPC_BEGIN_MESSAGE_MAP(CacheStorageDispatcher, message)
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheStorageHasSuccess,
OnCacheStorageHasSuccess)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheStorageOpenSuccess,
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheStorageOpenSuccess,
OnCacheStorageOpenSuccess)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheStorageDeleteSuccess,
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheStorageDeleteSuccess,
OnCacheStorageDeleteSuccess)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheStorageKeysSuccess,
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheStorageKeysSuccess,
OnCacheStorageKeysSuccess)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheStorageMatchSuccess,
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheStorageMatchSuccess,
OnCacheStorageMatchSuccess)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheStorageHasError,
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheStorageHasError,
OnCacheStorageHasError)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheStorageOpenError,
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheStorageOpenError,
OnCacheStorageOpenError)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheStorageDeleteError,
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheStorageDeleteError,
OnCacheStorageDeleteError)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheStorageKeysError,
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheStorageKeysError,
OnCacheStorageKeysError)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheStorageMatchError,
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheStorageMatchError,
OnCacheStorageMatchError)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheMatchSuccess,
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheMatchSuccess,
OnCacheMatchSuccess)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheMatchAllSuccess,
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheMatchAllSuccess,
OnCacheMatchAllSuccess)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheKeysSuccess,
- OnCacheKeysSuccess)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheBatchSuccess,
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheKeysSuccess, OnCacheKeysSuccess)
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheBatchSuccess,
OnCacheBatchSuccess)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheMatchError,
- OnCacheMatchError)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheMatchAllError,
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheMatchError, OnCacheMatchError)
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheMatchAllError,
OnCacheMatchAllError)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheKeysError,
- OnCacheKeysError)
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_CacheBatchError,
- OnCacheBatchError)
- IPC_MESSAGE_UNHANDLED(handled = false)
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheKeysError, OnCacheKeysError)
+ IPC_MESSAGE_HANDLER(CacheStorageMsg_CacheBatchError, OnCacheBatchError)
+ IPC_MESSAGE_UNHANDLED(handled = false)
IPC_END_MESSAGE_MAP()
return handled;
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheStorageHasSuccess(
- int thread_id,
- int request_id) {
+void CacheStorageDispatcher::OnCacheStorageHasSuccess(int thread_id,
+ int request_id) {
DCHECK_EQ(thread_id, CurrentWorkerId());
UMA_HISTOGRAM_TIMES("ServiceWorkerCache.CacheStorage.Has",
TimeTicks::Now() - has_times_[request_id]);
@@ -299,10 +286,9 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheStorageHasSuccess(
has_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheStorageOpenSuccess(
- int thread_id,
- int request_id,
- int cache_id) {
+void CacheStorageDispatcher::OnCacheStorageOpenSuccess(int thread_id,
+ int request_id,
+ int cache_id) {
DCHECK_EQ(thread_id, CurrentWorkerId());
WebCache* web_cache = new WebCache(weak_factory_.GetWeakPtr(), cache_id);
web_caches_.AddWithID(web_cache, cache_id);
@@ -315,9 +301,8 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheStorageOpenSuccess(
open_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheStorageDeleteSuccess(
- int thread_id,
- int request_id) {
+void CacheStorageDispatcher::OnCacheStorageDeleteSuccess(int thread_id,
+ int request_id) {
DCHECK_EQ(thread_id, CurrentWorkerId());
UMA_HISTOGRAM_TIMES("ServiceWorkerCache.CacheStorage.Delete",
TimeTicks::Now() - delete_times_[request_id]);
@@ -328,7 +313,7 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheStorageDeleteSuccess(
delete_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheStorageKeysSuccess(
+void CacheStorageDispatcher::OnCacheStorageKeysSuccess(
int thread_id,
int request_id,
const std::vector<base::string16>& keys) {
@@ -346,7 +331,7 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheStorageKeysSuccess(
keys_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheStorageMatchSuccess(
+void CacheStorageDispatcher::OnCacheStorageMatchSuccess(
int thread_id,
int request_id,
const ServiceWorkerResponse& response) {
@@ -363,7 +348,7 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheStorageMatchSuccess(
match_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheStorageHasError(
+void CacheStorageDispatcher::OnCacheStorageHasError(
int thread_id,
int request_id,
blink::WebServiceWorkerCacheError reason) {
@@ -375,7 +360,7 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheStorageHasError(
has_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheStorageOpenError(
+void CacheStorageDispatcher::OnCacheStorageOpenError(
int thread_id,
int request_id,
blink::WebServiceWorkerCacheError reason) {
@@ -387,7 +372,7 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheStorageOpenError(
open_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheStorageDeleteError(
+void CacheStorageDispatcher::OnCacheStorageDeleteError(
int thread_id,
int request_id,
blink::WebServiceWorkerCacheError reason) {
@@ -399,7 +384,7 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheStorageDeleteError(
delete_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheStorageKeysError(
+void CacheStorageDispatcher::OnCacheStorageKeysError(
int thread_id,
int request_id,
blink::WebServiceWorkerCacheError reason) {
@@ -411,7 +396,7 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheStorageKeysError(
keys_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheStorageMatchError(
+void CacheStorageDispatcher::OnCacheStorageMatchError(
int thread_id,
int request_id,
blink::WebServiceWorkerCacheError reason) {
@@ -423,7 +408,7 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheStorageMatchError(
match_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheMatchSuccess(
+void CacheStorageDispatcher::OnCacheMatchSuccess(
int thread_id,
int request_id,
const ServiceWorkerResponse& response) {
@@ -440,13 +425,13 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheMatchSuccess(
cache_match_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheMatchAllSuccess(
+void CacheStorageDispatcher::OnCacheMatchAllSuccess(
int thread_id,
int request_id,
const std::vector<ServiceWorkerResponse>& responses) {
DCHECK_EQ(thread_id, CurrentWorkerId());
- blink::WebVector<blink::WebServiceWorkerResponse>
- web_responses = WebResponsesFromResponses(responses);
+ blink::WebVector<blink::WebServiceWorkerResponse> web_responses =
+ WebResponsesFromResponses(responses);
UMA_HISTOGRAM_TIMES("ServiceWorkerCache.Cache.MatchAll",
TimeTicks::Now() - cache_match_all_times_[request_id]);
@@ -457,13 +442,13 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheMatchAllSuccess(
cache_match_all_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheKeysSuccess(
+void CacheStorageDispatcher::OnCacheKeysSuccess(
int thread_id,
int request_id,
const std::vector<ServiceWorkerFetchRequest>& requests) {
DCHECK_EQ(thread_id, CurrentWorkerId());
- blink::WebVector<blink::WebServiceWorkerRequest>
- web_requests = WebRequestsFromRequests(requests);
+ blink::WebVector<blink::WebServiceWorkerRequest> web_requests =
+ WebRequestsFromRequests(requests);
UMA_HISTOGRAM_TIMES("ServiceWorkerCache.Cache.Keys",
TimeTicks::Now() - cache_keys_times_[request_id]);
@@ -474,13 +459,13 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheKeysSuccess(
cache_keys_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheBatchSuccess(
+void CacheStorageDispatcher::OnCacheBatchSuccess(
int thread_id,
int request_id,
const std::vector<ServiceWorkerResponse>& responses) {
DCHECK_EQ(thread_id, CurrentWorkerId());
- blink::WebVector<blink::WebServiceWorkerResponse>
- web_responses = WebResponsesFromResponses(responses);
+ blink::WebVector<blink::WebServiceWorkerResponse> web_responses =
+ WebResponsesFromResponses(responses);
UMA_HISTOGRAM_TIMES("ServiceWorkerCache.Cache.Batch",
TimeTicks::Now() - cache_batch_times_[request_id]);
@@ -491,7 +476,7 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheBatchSuccess(
cache_batch_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheMatchError(
+void CacheStorageDispatcher::OnCacheMatchError(
int thread_id,
int request_id,
blink::WebServiceWorkerCacheError reason) {
@@ -503,7 +488,7 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheMatchError(
cache_match_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheMatchAllError(
+void CacheStorageDispatcher::OnCacheMatchAllError(
int thread_id,
int request_id,
blink::WebServiceWorkerCacheError reason) {
@@ -515,7 +500,7 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheMatchAllError(
cache_match_all_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheKeysError(
+void CacheStorageDispatcher::OnCacheKeysError(
int thread_id,
int request_id,
blink::WebServiceWorkerCacheError reason) {
@@ -527,7 +512,7 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheKeysError(
cache_keys_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::OnCacheBatchError(
+void CacheStorageDispatcher::OnCacheBatchError(
int thread_id,
int request_id,
blink::WebServiceWorkerCacheError reason) {
@@ -539,59 +524,59 @@ void ServiceWorkerCacheStorageDispatcher::OnCacheBatchError(
cache_batch_times_.erase(request_id);
}
-void ServiceWorkerCacheStorageDispatcher::dispatchHas(
+void CacheStorageDispatcher::dispatchHas(
WebServiceWorkerCacheStorage::CacheStorageCallbacks* callbacks,
const GURL& origin,
const blink::WebString& cacheName) {
int request_id = has_callbacks_.Add(callbacks);
has_times_[request_id] = base::TimeTicks::Now();
- Send(new ServiceWorkerHostMsg_CacheStorageHas(CurrentWorkerId(), request_id,
- origin, cacheName));
+ Send(new CacheStorageHostMsg_CacheStorageHas(CurrentWorkerId(), request_id,
+ origin, cacheName));
}
-void ServiceWorkerCacheStorageDispatcher::dispatchOpen(
+void CacheStorageDispatcher::dispatchOpen(
WebServiceWorkerCacheStorage::CacheStorageWithCacheCallbacks* callbacks,
const GURL& origin,
const blink::WebString& cacheName) {
int request_id = open_callbacks_.Add(callbacks);
open_times_[request_id] = base::TimeTicks::Now();
- Send(new ServiceWorkerHostMsg_CacheStorageOpen(CurrentWorkerId(), request_id,
- origin, cacheName));
+ Send(new CacheStorageHostMsg_CacheStorageOpen(CurrentWorkerId(), request_id,
+ origin, cacheName));
}
-void ServiceWorkerCacheStorageDispatcher::dispatchDelete(
+void CacheStorageDispatcher::dispatchDelete(
WebServiceWorkerCacheStorage::CacheStorageCallbacks* callbacks,
const GURL& origin,
const blink::WebString& cacheName) {
int request_id = delete_callbacks_.Add(callbacks);
delete_times_[request_id] = base::TimeTicks::Now();
- Send(new ServiceWorkerHostMsg_CacheStorageDelete(
- CurrentWorkerId(), request_id, origin, cacheName));
+ Send(new CacheStorageHostMsg_CacheStorageDelete(CurrentWorkerId(), request_id,
+ origin, cacheName));
}
-void ServiceWorkerCacheStorageDispatcher::dispatchKeys(
+void CacheStorageDispatcher::dispatchKeys(
WebServiceWorkerCacheStorage::CacheStorageKeysCallbacks* callbacks,
const GURL& origin) {
int request_id = keys_callbacks_.Add(callbacks);
keys_times_[request_id] = base::TimeTicks::Now();
- Send(new ServiceWorkerHostMsg_CacheStorageKeys(CurrentWorkerId(), request_id,
- origin));
+ Send(new CacheStorageHostMsg_CacheStorageKeys(CurrentWorkerId(), request_id,
+ origin));
}
-void ServiceWorkerCacheStorageDispatcher::dispatchMatch(
+void CacheStorageDispatcher::dispatchMatch(
WebServiceWorkerCacheStorage::CacheStorageMatchCallbacks* callbacks,
const GURL& origin,
const blink::WebServiceWorkerRequest& request,
const blink::WebServiceWorkerCache::QueryParams& query_params) {
int request_id = match_callbacks_.Add(callbacks);
match_times_[request_id] = base::TimeTicks::Now();
- Send(new ServiceWorkerHostMsg_CacheStorageMatch(
+ Send(new CacheStorageHostMsg_CacheStorageMatch(
CurrentWorkerId(), request_id, origin,
FetchRequestFromWebRequest(request),
QueryParamsFromWebQueryParams(query_params)));
}
-void ServiceWorkerCacheStorageDispatcher::dispatchMatchForCache(
+void CacheStorageDispatcher::dispatchMatchForCache(
int cache_id,
blink::WebServiceWorkerCache::CacheMatchCallbacks* callbacks,
const blink::WebServiceWorkerRequest& request,
@@ -599,13 +584,13 @@ void ServiceWorkerCacheStorageDispatcher::dispatchMatchForCache(
int request_id = cache_match_callbacks_.Add(callbacks);
cache_match_times_[request_id] = base::TimeTicks::Now();
- Send(new ServiceWorkerHostMsg_CacheMatch(
+ Send(new CacheStorageHostMsg_CacheMatch(
CurrentWorkerId(), request_id, cache_id,
FetchRequestFromWebRequest(request),
QueryParamsFromWebQueryParams(query_params)));
}
-void ServiceWorkerCacheStorageDispatcher::dispatchMatchAllForCache(
+void CacheStorageDispatcher::dispatchMatchAllForCache(
int cache_id,
blink::WebServiceWorkerCache::CacheWithResponsesCallbacks* callbacks,
const blink::WebServiceWorkerRequest& request,
@@ -613,13 +598,13 @@ void ServiceWorkerCacheStorageDispatcher::dispatchMatchAllForCache(
int request_id = cache_match_all_callbacks_.Add(callbacks);
cache_match_all_times_[request_id] = base::TimeTicks::Now();
- Send(new ServiceWorkerHostMsg_CacheMatchAll(
+ Send(new CacheStorageHostMsg_CacheMatchAll(
CurrentWorkerId(), request_id, cache_id,
FetchRequestFromWebRequest(request),
QueryParamsFromWebQueryParams(query_params)));
}
-void ServiceWorkerCacheStorageDispatcher::dispatchKeysForCache(
+void CacheStorageDispatcher::dispatchKeysForCache(
int cache_id,
blink::WebServiceWorkerCache::CacheWithRequestsCallbacks* callbacks,
const blink::WebServiceWorkerRequest* request,
@@ -627,38 +612,38 @@ void ServiceWorkerCacheStorageDispatcher::dispatchKeysForCache(
int request_id = cache_keys_callbacks_.Add(callbacks);
cache_keys_times_[request_id] = base::TimeTicks::Now();
- Send(new ServiceWorkerHostMsg_CacheKeys(
+ Send(new CacheStorageHostMsg_CacheKeys(
CurrentWorkerId(), request_id, cache_id,
request ? FetchRequestFromWebRequest(*request)
: ServiceWorkerFetchRequest(),
QueryParamsFromWebQueryParams(query_params)));
}
-void ServiceWorkerCacheStorageDispatcher::dispatchBatchForCache(
+void CacheStorageDispatcher::dispatchBatchForCache(
int cache_id,
blink::WebServiceWorkerCache::CacheWithResponsesCallbacks* callbacks,
- const blink::WebVector<
- blink::WebServiceWorkerCache::BatchOperation>& web_operations) {
+ const blink::WebVector<blink::WebServiceWorkerCache::BatchOperation>&
+ web_operations) {
int request_id = cache_batch_callbacks_.Add(callbacks);
cache_batch_times_[request_id] = base::TimeTicks::Now();
- std::vector<ServiceWorkerBatchOperation> operations;
+ std::vector<CacheStorageBatchOperation> operations;
operations.reserve(web_operations.size());
for (size_t i = 0; i < web_operations.size(); ++i) {
operations.push_back(
BatchOperationFromWebBatchOperation(web_operations[i]));
}
- Send(new ServiceWorkerHostMsg_CacheBatch(CurrentWorkerId(), request_id,
- cache_id, operations));
+ Send(new CacheStorageHostMsg_CacheBatch(CurrentWorkerId(), request_id,
+ cache_id, operations));
}
-void ServiceWorkerCacheStorageDispatcher::OnWebCacheDestruction(int cache_id) {
+void CacheStorageDispatcher::OnWebCacheDestruction(int cache_id) {
web_caches_.Remove(cache_id);
- Send(new ServiceWorkerHostMsg_CacheClosed(cache_id));
+ Send(new CacheStorageHostMsg_CacheClosed(cache_id));
}
-void ServiceWorkerCacheStorageDispatcher::PopulateWebResponseFromResponse(
+void CacheStorageDispatcher::PopulateWebResponseFromResponse(
const ServiceWorkerResponse& response,
blink::WebServiceWorkerResponse* web_response) {
web_response->setURL(response.url);
@@ -675,12 +660,12 @@ void ServiceWorkerCacheStorageDispatcher::PopulateWebResponseFromResponse(
web_response->setBlob(blink::WebString::fromUTF8(response.blob_uuid),
response.blob_size);
// Let the host know that it can release its reference to the blob.
- Send(new ServiceWorkerHostMsg_BlobDataHandled(response.blob_uuid));
+ Send(new CacheStorageHostMsg_BlobDataHandled(response.blob_uuid));
}
}
blink::WebVector<blink::WebServiceWorkerResponse>
-ServiceWorkerCacheStorageDispatcher::WebResponsesFromResponses(
+CacheStorageDispatcher::WebResponsesFromResponses(
const std::vector<ServiceWorkerResponse>& responses) {
blink::WebVector<blink::WebServiceWorkerResponse> web_responses(
responses.size());

Powered by Google App Engine
This is Rietveld 408576698