Implement EvictOriginData in QuotaManager.

webkit/quota/quota_manager.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 "webkit/quota/quota_manager.h"
 
 #include <deque>
 #include <algorithm>
 
 #include "base/callback.h"
 #include "base/file_path.h"
 #include "base/memory/ref_counted.h"
 #include "base/message_loop_proxy.h"
 #include "base/stl_util-inl.h"
 #include "base/sys_info.h"
 #include "net/base/net_util.h"
+#include "webkit/quota/quota_client.h"
 #include "webkit/quota/quota_database.h"
 #include "webkit/quota/quota_types.h"
 #include "webkit/quota/usage_tracker.h"
 
 using base::ScopedCallbackFactory;
 
 namespace quota {
 
 namespace {
 // Returns the initial size of the temporary storage quota.
@@ skipping 481 matching lines @@
                            const FilePath& profile_path,
                            base::MessageLoopProxy* io_thread,
                            base::MessageLoopProxy* db_thread)
   : is_incognito_(is_incognito),
     profile_path_(profile_path),
     proxy_(new QuotaManagerProxy(
         ALLOW_THIS_IN_INITIALIZER_LIST(this), io_thread)),
     db_disabled_(false),
     io_thread_(io_thread),
     db_thread_(db_thread),
-    temporary_global_quota_(-1) {
+    num_deletion_requested_clients_(0),
+    num_deleted_clients_(0),
+    temporary_global_quota_(-1),
+    callback_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) {
 }
 
 QuotaManager::~QuotaManager() {
   DCHECK(io_thread_->BelongsToCurrentThread());
   proxy_->manager_ = NULL;
   std::for_each(clients_.begin(), clients_.end(),
                 std::mem_fun(&QuotaClient::OnQuotaManagerDestroyed));
   if (database_.get())
     db_thread_->DeleteSoon(FROM_HERE, database_.release());
 }
@@ skipping 199 matching lines @@
   if (db_disabled_) {
     callback->Run(GURL());
     delete callback;
     return;
   }
   scoped_refptr<GetLRUOriginTask> task(new GetLRUOriginTask(
       this, database_.get(), db_thread_, type, origins_in_use_, callback));
   task->Start();
 }
 
+void QuotaManager::OnOriginDataEvicted(
+    QuotaStatusCode status) {
+  LOG(ERROR) << "QM::OnOriginDataDeleted";
+  DCHECK(io_thread_->BelongsToCurrentThread());
+
+  if (status != kQuotaStatusOk) {
+    // TODO(dmikurube): Handle error.
+  }
+
+  ++num_deleted_clients_;
+  DCHECK(num_deleted_clients_ <= num_deletion_requested_clients_);
+  if (num_deleted_clients_ == num_deletion_requested_clients_) {
+    num_deletion_requested_clients_ = 0;
+    num_deleted_clients_ = 0;
+
+    // TODO(dmikurube): Get usage, quota and physical space and then callback.
+    evict_origin_data_callback_->Run(kQuotaStatusOk);
+    delete evict_origin_data_callback_;

[michaeln, 2011/05/17 19:30:01]

is the callback leaked if the class is destructed prior to completion?

[Dai Mikurube (NOT FULLTIME), 2011/05/18 04:34:48]

Done.

+  }
+}
+
 void QuotaManager::EvictOriginData(
     const GURL& origin,
     StorageType type,
     EvictOriginDataCallback* callback) {
-  // TODO(dmikurube): Implement it.
+  LOG(ERROR) << "QM::DeleteOriginData";

[michaeln, 2011/05/17 19:30:01]

Please fixup the LOG(ERROR) usage throughout. It's not an error to have this
method called.

[Dai Mikurube (NOT FULLTIME), 2011/05/18 04:34:48]

Yeah, I'll remove them finally for other changes.  They're just local messages
for debugging.  I was uploading the code just to share the current status...

+  DCHECK(io_thread_->BelongsToCurrentThread());

[michaeln, 2011/05/17 19:30:01]

Since LazyInitialize has this DCHECK, consider removing it from this method

[Dai Mikurube (NOT FULLTIME), 2011/05/18 04:34:48]

LazyInitialize here was replaced with DCHECK(database_.get()) by Kinuko-san's
comment.

+  LazyInitialize();
+
+  int num_clients = clients_.size();
+
+  if (origin.is_empty() || num_clients == 0 || num_deleted_clients_ > 0) {
+    callback->Run(kQuotaStatusOk);
+    delete callback;
+    return;
+  }
+
+  num_deletion_requested_clients_ = num_clients;
+  num_deleted_clients_ = 0;
+
+  for (QuotaClientList::iterator p = clients_.begin();
+       p != clients_.end();
+       ++p) {
+    evict_origin_data_callback_ = callback;

[michaeln, 2011/05/17 19:30:01]

maybe move this assignment up out of the loop

[Dai Mikurube (NOT FULLTIME), 2011/05/18 04:34:48]

Done.

+    (*p)->DeleteOriginData(origin, kStorageTypeTemporary, callback_factory_.
+        NewCallback(&QuotaManager::OnOriginDataEvicted));
+  }
 }
 
 void QuotaManager::GetUsageAndQuotaForEviction(
     GetUsageAndQuotaForEvictionCallback* callback) {
   // TODO(dmikurube): Implement it.
 }
 
 void QuotaManager::DeleteOnCorrectThread() const {
   if (!io_thread_->BelongsToCurrentThread()) {
     io_thread_->DeleteSoon(FROM_HERE, this);
@@ skipping 87 matching lines @@
 
 QuotaManagerProxy::QuotaManagerProxy(
     QuotaManager* manager, base::MessageLoopProxy* io_thread)
     : manager_(manager), io_thread_(io_thread) {
 }
 
 QuotaManagerProxy::~QuotaManagerProxy() {
 }
 
 }  // namespace quota