WIP Durable storage, chrome side

content/child/quota_dispatcher.cc

 // Copyright (c) 2011 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/child/quota_dispatcher.h"
 
 #include "base/basictypes.h"
 #include "base/lazy_instance.h"
 #include "base/threading/thread_local.h"
 #include "content/child/quota_message_filter.h"
@@ skipping 120 matching lines @@
   params.render_view_id = render_view_id;
   params.request_id = request_id;
   params.origin_url = origin_url;
   params.storage_type = type;
   params.requested_size = requested_size;
   params.user_gesture =
       blink::WebUserGestureIndicator::isProcessingUserGesture();
   thread_safe_sender_->Send(new QuotaHostMsg_RequestStorageQuota(params));
 }
 
+void QuotaDispatcher::RequestDurability(
+    int render_view_id,
+    const GURL& origin_url,
+    Callback* callback) {
+  DCHECK(callback);
+  DCHECK(CurrentWorkerId() == 0);
+  int request_id = quota_message_filter_->GenerateRequestID(CurrentWorkerId());
+  LOG(ERROR) << "Got into QuotaDispatcher::RequestDurability request_id = "
+             << request_id;
+  pending_quota_callbacks_.AddWithID(callback, request_id);
+
+  StorageQuotaParams params;
+  params.render_view_id = render_view_id;
+  params.request_id = request_id;
+  params.origin_url = origin_url;
+  params.storage_type = storage::kStorageTypeDurable;
+  params.user_gesture =
+      blink::WebUserGestureIndicator::isProcessingUserGesture();
+  thread_safe_sender_->Send(new QuotaHostMsg_RequestStorageQuota(params));
+}
+
 // static
 QuotaDispatcher::Callback*
 QuotaDispatcher::CreateWebStorageQuotaCallbacksWrapper(
     blink::WebStorageQuotaCallbacks callbacks) {
   return new WebStorageQuotaDispatcherCallback(callbacks);
 }
 
 void QuotaDispatcher::DidGrantStorageQuota(
     int request_id,
     int64 current_usage,
@@ skipping 12 matching lines @@
   DCHECK(callback);
   callback->DidQueryStorageUsageAndQuota(current_usage, current_quota);
   pending_quota_callbacks_.Remove(request_id);
 }
 
 void QuotaDispatcher::DidFail(
     int request_id,
     QuotaStatusCode error) {
   Callback* callback = pending_quota_callbacks_.Lookup(request_id);
   DCHECK(callback);
+  LOG(ERROR) << "Got a DidFail error for request_id " << request_id;
   callback->DidFail(error);
   pending_quota_callbacks_.Remove(request_id);
 }
 
 static_assert(int(blink::WebStorageQuotaTypeTemporary) ==
                   int(storage::kStorageTypeTemporary),
               "mismatching enums: kStorageTypeTemporary");
 static_assert(int(blink::WebStorageQuotaTypePersistent) ==
                   int(storage::kStorageTypePersistent),
               "mismatching enums: kStorageTypePersistent");
 
 static_assert(int(blink::WebStorageQuotaErrorNotSupported) ==
                   int(storage::kQuotaErrorNotSupported),
               "mismatching enums: kQuotaErrorNotSupported");
 static_assert(int(blink::WebStorageQuotaErrorAbort) ==
                   int(storage::kQuotaErrorAbort),
               "mismatching enums: kQuotaErrorAbort");
 
 }  // namespace content