Implement QuotaTemporaryStorageEvictor.

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_database.h"
+#include "webkit/quota/quota_temporary_storage_evictor.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.
 // (This just gives a default initial size; once its initial size is determined
@@ skipping 435 matching lines @@
 
   if (is_incognito_)
     return;
 
   database_.reset(new QuotaDatabase(profile_path_.AppendASCII(kDatabaseName)));
 
   temporary_usage_tracker_.reset(
       new UsageTracker(clients_, kStorageTypeTemporary));
   persistent_usage_tracker_.reset(
       new UsageTracker(clients_, kStorageTypePersistent));
+  // TODO(dmikurube): Change this hard-coded 3 seconds.
+  temporary_storage_evictor_.reset(new QuotaTemporaryStorageEvictor(
+      this, database_.get(), 3000, db_thread_));

[kinuko, 2011/05/11 12:43:30]

Maybe this initialization could be delayed until the InitializeTask finishes? 
(If it fails on some db failure we could just disable running the evictor)

[Dai Mikurube (NOT FULLTIME), 2011/05/12 02:45:50]

Hmm, added a TODO for now.

 
   scoped_refptr<InitializeTask> task(
       new InitializeTask(this, database_.get(), db_thread_, profile_path_));
   task->Start();
+
+  temporary_storage_evictor_->Start();
 }
 
 void QuotaManager::RegisterClient(QuotaClient* client) {
   DCHECK(io_thread_->BelongsToCurrentThread());
   DCHECK(!database_.get());
   clients_.push_back(client);
 }
 
 void QuotaManager::NotifyStorageModified(
     QuotaClient::ID client_id,
@@ skipping 76 matching lines @@
 
 QuotaManagerProxy::QuotaManagerProxy(
     QuotaManager* manager, base::MessageLoopProxy* io_thread)
     : manager_(manager), io_thread_(io_thread) {
 }
 
 QuotaManagerProxy::~QuotaManagerProxy() {
 }
 
 }  // namespace quota