OLD | NEW |
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 Loading... |
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 Loading... |
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 Loading... |
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 |
OLD | NEW |