Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(445)

Side by Side Diff: chrome/browser/sync_file_system/drive_metadata_store.cc

Issue 11275088: Remove implicit scoped_refptr operator T* Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 8 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "chrome/browser/sync_file_system/drive_metadata_store.h" 5 #include "chrome/browser/sync_file_system/drive_metadata_store.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/callback.h" 8 #include "base/callback.h"
9 #include "base/file_path.h" 9 #include "base/file_path.h"
10 #include "base/location.h" 10 #include "base/location.h"
(...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after
97 DriveMetadataStore::~DriveMetadataStore() { 97 DriveMetadataStore::~DriveMetadataStore() {
98 DCHECK(CalledOnValidThread()); 98 DCHECK(CalledOnValidThread());
99 file_task_runner_->DeleteSoon(FROM_HERE, db_.release()); 99 file_task_runner_->DeleteSoon(FROM_HERE, db_.release());
100 } 100 }
101 101
102 void DriveMetadataStore::Initialize(const InitializationCallback& callback) { 102 void DriveMetadataStore::Initialize(const InitializationCallback& callback) {
103 DCHECK(CalledOnValidThread()); 103 DCHECK(CalledOnValidThread());
104 int64* largest_changestamp = new int64; 104 int64* largest_changestamp = new int64;
105 MetadataMap* metadata_map = new MetadataMap; 105 MetadataMap* metadata_map = new MetadataMap;
106 base::PostTaskAndReplyWithResult( 106 base::PostTaskAndReplyWithResult(
107 file_task_runner_, FROM_HERE, 107 file_task_runner_.get(), FROM_HERE,
108 base::Bind(InitializeDBOnFileThread, 108 base::Bind(InitializeDBOnFileThread,
109 db_.get(), largest_changestamp, metadata_map), 109 db_.get(), largest_changestamp, metadata_map),
110 base::Bind(&DriveMetadataStore::DidInitialize, AsWeakPtr(), 110 base::Bind(&DriveMetadataStore::DidInitialize, AsWeakPtr(),
111 callback, 111 callback,
112 base::Owned(largest_changestamp), 112 base::Owned(largest_changestamp),
113 base::Owned(metadata_map))); 113 base::Owned(metadata_map)));
114 } 114 }
115 115
116 void DriveMetadataStore::DidInitialize(const InitializationCallback& callback, 116 void DriveMetadataStore::DidInitialize(const InitializationCallback& callback,
117 const int64* largest_changestamp, 117 const int64* largest_changestamp,
(...skipping 13 matching lines...) Expand all
131 metadata_map_.swap(*metadata_map); 131 metadata_map_.swap(*metadata_map);
132 // |largest_changestamp_| is set to 0 for a fresh empty database. 132 // |largest_changestamp_| is set to 0 for a fresh empty database.
133 callback.Run(status, largest_changestamp_ <= 0); 133 callback.Run(status, largest_changestamp_ <= 0);
134 } 134 }
135 135
136 void DriveMetadataStore::SetLargestChangeStamp(int64 largest_changestamp) { 136 void DriveMetadataStore::SetLargestChangeStamp(int64 largest_changestamp) {
137 DCHECK(CalledOnValidThread()); 137 DCHECK(CalledOnValidThread());
138 DCHECK_EQ(fileapi::SYNC_STATUS_OK, db_status_); 138 DCHECK_EQ(fileapi::SYNC_STATUS_OK, db_status_);
139 largest_changestamp_ = largest_changestamp; 139 largest_changestamp_ = largest_changestamp;
140 base::PostTaskAndReplyWithResult( 140 base::PostTaskAndReplyWithResult(
141 file_task_runner_, FROM_HERE, 141 file_task_runner_.get(), FROM_HERE,
142 base::Bind(&DriveMetadataDB::SetLargestChangestamp, 142 base::Bind(&DriveMetadataDB::SetLargestChangestamp,
143 base::Unretained(db_.get()), largest_changestamp), 143 base::Unretained(db_.get()), largest_changestamp),
144 base::Bind(&DriveMetadataStore::UpdateDBStatus, AsWeakPtr())); 144 base::Bind(&DriveMetadataStore::UpdateDBStatus, AsWeakPtr()));
145 } 145 }
146 146
147 int64 DriveMetadataStore::GetLargestChangeStamp() const { 147 int64 DriveMetadataStore::GetLargestChangeStamp() const {
148 DCHECK(CalledOnValidThread()); 148 DCHECK(CalledOnValidThread());
149 DCHECK_EQ(fileapi::SYNC_STATUS_OK, db_status_); 149 DCHECK_EQ(fileapi::SYNC_STATUS_OK, db_status_);
150 return largest_changestamp_; 150 return largest_changestamp_;
151 } 151 }
152 152
153 SyncStatusCode DriveMetadataStore::UpdateEntry(const FileSystemURL& url, 153 SyncStatusCode DriveMetadataStore::UpdateEntry(const FileSystemURL& url,
154 const DriveMetadata& metadata) { 154 const DriveMetadata& metadata) {
155 DCHECK(CalledOnValidThread()); 155 DCHECK(CalledOnValidThread());
156 DCHECK_EQ(fileapi::SYNC_STATUS_OK, db_status_); 156 DCHECK_EQ(fileapi::SYNC_STATUS_OK, db_status_);
157 std::pair<MetadataMap::iterator, bool> result = 157 std::pair<MetadataMap::iterator, bool> result =
158 metadata_map_.insert(std::make_pair(url, metadata)); 158 metadata_map_.insert(std::make_pair(url, metadata));
159 if (!result.second) 159 if (!result.second)
160 result.first->second = metadata; 160 result.first->second = metadata;
161 base::PostTaskAndReplyWithResult( 161 base::PostTaskAndReplyWithResult(
162 file_task_runner_, FROM_HERE, 162 file_task_runner_.get(), FROM_HERE,
163 base::Bind(&DriveMetadataDB::UpdateEntry, base::Unretained(db_.get()), 163 base::Bind(&DriveMetadataDB::UpdateEntry, base::Unretained(db_.get()),
164 url, metadata), 164 url, metadata),
165 base::Bind(&DriveMetadataStore::UpdateDBStatus, AsWeakPtr())); 165 base::Bind(&DriveMetadataStore::UpdateDBStatus, AsWeakPtr()));
166 return result.second ? 166 return result.second ?
167 fileapi::SYNC_STATUS_OK : 167 fileapi::SYNC_STATUS_OK :
168 fileapi::SYNC_FILE_ERROR_EXISTS; 168 fileapi::SYNC_FILE_ERROR_EXISTS;
169 } 169 }
170 170
171 SyncStatusCode DriveMetadataStore::DeleteEntry(const FileSystemURL& url) { 171 SyncStatusCode DriveMetadataStore::DeleteEntry(const FileSystemURL& url) {
172 DCHECK(CalledOnValidThread()); 172 DCHECK(CalledOnValidThread());
173 if (metadata_map_.erase(url) == 1) { 173 if (metadata_map_.erase(url) == 1) {
174 base::PostTaskAndReplyWithResult( 174 base::PostTaskAndReplyWithResult(
175 file_task_runner_, FROM_HERE, 175 file_task_runner_.get(), FROM_HERE,
176 base::Bind(&DriveMetadataDB::DeleteEntry, 176 base::Bind(&DriveMetadataDB::DeleteEntry,
177 base::Unretained(db_.get()), url), 177 base::Unretained(db_.get()), url),
178 base::Bind(&DriveMetadataStore::UpdateDBStatus, AsWeakPtr())); 178 base::Bind(&DriveMetadataStore::UpdateDBStatus, AsWeakPtr()));
179 return fileapi::SYNC_STATUS_OK; 179 return fileapi::SYNC_STATUS_OK;
180 } 180 }
181 return fileapi::SYNC_DATABASE_ERROR_NOT_FOUND; 181 return fileapi::SYNC_DATABASE_ERROR_NOT_FOUND;
182 } 182 }
183 183
184 SyncStatusCode DriveMetadataStore::ReadEntry(const FileSystemURL& url, 184 SyncStatusCode DriveMetadataStore::ReadEntry(const FileSystemURL& url,
185 DriveMetadata* metadata) const { 185 DriveMetadata* metadata) const {
(...skipping 160 matching lines...) Expand 10 before | Expand all | Expand 10 after
346 bool success = fileapi::SerializeSyncableFileSystemURL(url, &url_string); 346 bool success = fileapi::SerializeSyncableFileSystemURL(url, &url_string);
347 DCHECK(success); 347 DCHECK(success);
348 348
349 leveldb::Status status = db_->Delete( 349 leveldb::Status status = db_->Delete(
350 leveldb::WriteOptions(), 350 leveldb::WriteOptions(),
351 kDriveMetadataKeyPrefix + url_string); 351 kDriveMetadataKeyPrefix + url_string);
352 return fileapi::LevelDBStatusToSyncStatusCode(status); 352 return fileapi::LevelDBStatusToSyncStatusCode(status);
353 } 353 }
354 354
355 } // namespace sync_file_system 355 } // namespace sync_file_system
OLDNEW
« no previous file with comments | « chrome/browser/sync/test/integration/sync_test.cc ('k') | chrome/browser/task_manager/task_manager_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698