OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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_backend/metadata_database.h" | 5 #include "chrome/browser/sync_file_system/drive_backend/metadata_database.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <stack> | 8 #include <stack> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
(...skipping 1250 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1261 tracker_to_be_activated->set_needs_folder_listing(true); | 1261 tracker_to_be_activated->set_needs_folder_listing(true); |
1262 } | 1262 } |
1263 tracker_to_be_activated->set_dirty(false); | 1263 tracker_to_be_activated->set_dirty(false); |
1264 | 1264 |
1265 index_->StoreFileTracker(tracker_to_be_activated.Pass()); | 1265 index_->StoreFileTracker(tracker_to_be_activated.Pass()); |
1266 | 1266 |
1267 WriteToDatabase(callback); | 1267 WriteToDatabase(callback); |
1268 return ACTIVATION_PENDING; | 1268 return ACTIVATION_PENDING; |
1269 } | 1269 } |
1270 | 1270 |
1271 void MetadataDatabase::LowerTrackerPriority(int64 tracker_id) { | 1271 void MetadataDatabase::DemoteTracker(int64 tracker_id) { |
1272 DCHECK(worker_sequence_checker_.CalledOnValidSequencedThread()); | 1272 DCHECK(worker_sequence_checker_.CalledOnValidSequencedThread()); |
1273 index_->DemoteDirtyTracker(tracker_id); | 1273 index_->DemoteDirtyTracker(tracker_id); |
1274 WriteToDatabase(base::Bind(&EmptyStatusCallback)); | 1274 WriteToDatabase(base::Bind(&EmptyStatusCallback)); |
1275 } | 1275 } |
1276 | 1276 |
1277 bool MetadataDatabase::PromoteLowerPriorityTrackersToNormal() { | 1277 bool MetadataDatabase::PromoteDemotedTrackers() { |
1278 DCHECK(worker_sequence_checker_.CalledOnValidSequencedThread()); | 1278 DCHECK(worker_sequence_checker_.CalledOnValidSequencedThread()); |
1279 bool promoted = index_->PromoteDemotedDirtyTrackers(); | 1279 bool promoted = index_->PromoteDemotedDirtyTrackers(); |
1280 WriteToDatabase(base::Bind(&EmptyStatusCallback)); | 1280 WriteToDatabase(base::Bind(&EmptyStatusCallback)); |
1281 return promoted; | 1281 return promoted; |
1282 } | 1282 } |
1283 | 1283 |
1284 void MetadataDatabase::PromoteDemotedTracker(int64 tracker_id) { | 1284 void MetadataDatabase::PromoteDemotedTracker(int64 tracker_id) { |
1285 DCHECK(worker_sequence_checker_.CalledOnValidSequencedThread()); | 1285 DCHECK(worker_sequence_checker_.CalledOnValidSequencedThread()); |
1286 index_->PromoteDemotedDirtyTracker(tracker_id); | 1286 index_->PromoteDemotedDirtyTracker(tracker_id); |
1287 WriteToDatabase(base::Bind(&EmptyStatusCallback)); | 1287 WriteToDatabase(base::Bind(&EmptyStatusCallback)); |
1288 } | 1288 } |
1289 | 1289 |
1290 bool MetadataDatabase::GetNormalPriorityDirtyTracker( | 1290 bool MetadataDatabase::GetDirtyTracker( |
1291 FileTracker* tracker_out) const { | 1291 FileTracker* tracker_out) const { |
1292 DCHECK(worker_sequence_checker_.CalledOnValidSequencedThread()); | 1292 DCHECK(worker_sequence_checker_.CalledOnValidSequencedThread()); |
1293 | 1293 |
1294 int64 dirty_tracker_id = index_->PickDirtyTracker(); | 1294 int64 dirty_tracker_id = index_->PickDirtyTracker(); |
1295 if (!dirty_tracker_id) | 1295 if (!dirty_tracker_id) |
1296 return false; | 1296 return false; |
1297 | 1297 |
1298 if (tracker_out) { | 1298 if (tracker_out) { |
1299 if (!index_->GetFileTracker(dirty_tracker_id, tracker_out)) { | 1299 if (!index_->GetFileTracker(dirty_tracker_id, tracker_out)) { |
1300 NOTREACHED(); | 1300 NOTREACHED(); |
1301 return false; | 1301 return false; |
1302 } | 1302 } |
1303 } | 1303 } |
1304 return true; | 1304 return true; |
1305 } | 1305 } |
1306 | 1306 |
1307 bool MetadataDatabase::HasLowPriorityDirtyTracker() const { | 1307 bool MetadataDatabase::HasDemotedDirtyTracker() const { |
1308 DCHECK(worker_sequence_checker_.CalledOnValidSequencedThread()); | 1308 DCHECK(worker_sequence_checker_.CalledOnValidSequencedThread()); |
1309 return index_->HasDemotedDirtyTracker(); | 1309 return index_->HasDemotedDirtyTracker(); |
1310 } | 1310 } |
1311 | 1311 |
1312 bool MetadataDatabase::HasDirtyTracker() const { | 1312 bool MetadataDatabase::HasDirtyTracker() const { |
1313 DCHECK(worker_sequence_checker_.CalledOnValidSequencedThread()); | 1313 DCHECK(worker_sequence_checker_.CalledOnValidSequencedThread()); |
1314 return index_->PickDirtyTracker() != kInvalidTrackerID; | 1314 return index_->PickDirtyTracker() != kInvalidTrackerID; |
1315 } | 1315 } |
1316 | 1316 |
1317 size_t MetadataDatabase::CountDirtyTracker() const { | 1317 size_t MetadataDatabase::CountDirtyTracker() const { |
(...skipping 660 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1978 return false; | 1978 return false; |
1979 | 1979 |
1980 if (!parents.empty()) | 1980 if (!parents.empty()) |
1981 return false; | 1981 return false; |
1982 | 1982 |
1983 return true; | 1983 return true; |
1984 } | 1984 } |
1985 | 1985 |
1986 } // namespace drive_backend | 1986 } // namespace drive_backend |
1987 } // namespace sync_file_system | 1987 } // namespace sync_file_system |
OLD | NEW |