drive: DriveIntegrationService owns ResourceMetadataStorage

chrome/browser/chromeos/drive/resource_metadata_storage.cc

 // Copyright 2013 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 "chrome/browser/chromeos/drive/resource_metadata_storage.h"
 
+#include "base/bind.h"
 #include "base/file_util.h"
+#include "base/location.h"
 #include "base/logging.h"
 #include "base/metrics/histogram.h"
+#include "base/sequenced_task_runner.h"
 #include "base/threading/thread_restrictions.h"
 #include "chrome/browser/chromeos/drive/drive.pb.h"
 #include "third_party/leveldatabase/src/include/leveldb/db.h"
 #include "third_party/leveldatabase/src/include/leveldb/write_batch.h"
 
 namespace drive {
+namespace internal {
 
 namespace {
 
 // Enum to describe DB initialization status.
 enum DBInitStatus {
   DB_INIT_SUCCESS,
   DB_INIT_NOT_FOUND,
   DB_INIT_CORRUPTION,
   DB_INIT_IO_ERROR,
   DB_INIT_FAILED,
@@ skipping 161 matching lines @@
       // Drop the suffix |kDBKeyDelimeter + kCacheEntryKeySuffix| from the key.
       const size_t kSuffixLength = arraysize(kCacheEntryKeySuffix) - 1;
       const int id_length = it_->key().size() - 1 - kSuffixLength;
       resource_id_.assign(it_->key().data(), id_length);
       break;
     }
   }
 }
 
 ResourceMetadataStorage::ResourceMetadataStorage(
-    const base::FilePath& directory_path)
-    : directory_path_(directory_path) {
+    const base::FilePath& directory_path,
+    base::SequencedTaskRunner* blocking_task_runner)
+    : directory_path_(directory_path),
+      blocking_task_runner_(blocking_task_runner) {
 }
 
-ResourceMetadataStorage::~ResourceMetadataStorage() {
-  base::ThreadRestrictions::AssertIOAllowed();
+void ResourceMetadataStorage::Destroy() {
+  blocking_task_runner_->PostTask(
+      FROM_HERE,
+      base::Bind(&ResourceMetadataStorage::DestroyOnBlockingPool,
+                 base::Unretained(this)));
 }
 
 bool ResourceMetadataStorage::Initialize() {
   base::ThreadRestrictions::AssertIOAllowed();
 
   // Remove unused child map DB.
   const base::FilePath child_map_path = directory_path_.Append(kChildMapDBName);
   file_util::Delete(child_map_path, true /* recursive */);
 
   resource_map_.reset();
@@ skipping 244 matching lines @@
 
 scoped_ptr<ResourceMetadataStorage::CacheEntryIterator>
 ResourceMetadataStorage::GetCacheEntryIterator() {
   base::ThreadRestrictions::AssertIOAllowed();
 
   scoped_ptr<leveldb::Iterator> it(
       resource_map_->NewIterator(leveldb::ReadOptions()));
   return make_scoped_ptr(new CacheEntryIterator(it.Pass()));
 }
 
+ResourceMetadataStorage::~ResourceMetadataStorage() {
+  base::ThreadRestrictions::AssertIOAllowed();
+}
+
+void ResourceMetadataStorage::DestroyOnBlockingPool() {
+  delete this;
+}
+
 // static
 std::string ResourceMetadataStorage::GetChildEntryKey(
     const std::string& parent_resource_id,
     const std::string& child_name) {
   std::string key = parent_resource_id;
   key.push_back(kDBKeyDelimeter);
   key.append(child_name);
   key.push_back(kDBKeyDelimeter);
   return key;
 }
@@ skipping 109 matching lines @@
     }
   }
   if (!it->status().ok() || num_child_entries != num_entries_with_parent) {
     DLOG(ERROR) << "Error during checking resource map. status = "
                 << it->status().ToString();
     return false;
   }
   return true;
 }
 
+}  // namespace internal
 }  // namespace drive