CacheStorage: Support multiple batch operations

content/browser/cache_storage/cache_storage_dispatcher_host.cc

 // Copyright 2015 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.
 
 #include "content/browser/cache_storage/cache_storage_dispatcher_host.h"
 
 #include "base/bind.h"
 #include "base/logging.h"
 #include "base/strings/string16.h"
 #include "base/strings/utf_string_conversions.h"
@@ skipping 253 matching lines @@
         blink::WebServiceWorkerCacheErrorNotImplemented));
     return;
   }
 
   IDToCacheMap::iterator it = id_to_cache_map_.find(cache_id);
   if (it == id_to_cache_map_.end()) {
     Send(new CacheStorageMsg_CacheBatchError(
         thread_id, request_id, blink::WebServiceWorkerCacheErrorNotFound));
     return;
   }
-
-  const CacheStorageBatchOperation& operation = operations[0];
-
   scoped_refptr<CacheStorageCache> 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 == CACHE_STORAGE_CACHE_OPERATION_TYPE_DELETE) {
-    cache->Delete(scoped_request.Pass(),
-                  base::Bind(&CacheStorageDispatcherHost::OnCacheBatchCallback,
+  cache->BatchOperation(
+      operations, base::Bind(&CacheStorageDispatcherHost::OnCacheBatchCallback,
                              this, thread_id, request_id, cache));
-    return;
-  }
-
-  if (operation.operation_type == CACHE_STORAGE_CACHE_OPERATION_TYPE_PUT) {
-    // We don't support streaming for cache.
-    DCHECK(operation.response.stream_url.is_empty());
-    scoped_ptr<ServiceWorkerResponse> scoped_response(new ServiceWorkerResponse(
-        operation.response.url, operation.response.status_code,
-        operation.response.status_text, operation.response.response_type,
-        operation.response.headers, operation.response.blob_uuid,
-        operation.response.blob_size, operation.response.stream_url));
-    cache->Put(scoped_request.Pass(), scoped_response.Pass(),
-               base::Bind(&CacheStorageDispatcherHost::OnCacheBatchCallback,
-                          this, thread_id, request_id, cache));
-
-    return;
-  }
-
-  Send(new CacheStorageMsg_CacheBatchError(
-      thread_id, request_id, blink::WebServiceWorkerCacheErrorNotImplemented));
 }
 
 void CacheStorageDispatcherHost::OnCacheClosed(int cache_id) {
   DropCacheReference(cache_id);
 }
 
 void CacheStorageDispatcherHost::OnBlobDataHandled(const std::string& uuid) {
   DropBlobDataHandle(uuid);
 }
 
@@ skipping 163 matching lines @@
   UUIDToBlobDataHandleList::iterator it = blob_handle_store_.find(uuid);
   if (it == blob_handle_store_.end())
     return;
   DCHECK(!it->second.empty());
   it->second.pop_front();
   if (it->second.empty())
     blob_handle_store_.erase(it);
 }
 
 }  // namespace content