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 877 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
888 MakeTrackerActive(tracker->tracker_id(), batch.get()); | 888 MakeTrackerActive(tracker->tracker_id(), batch.get()); |
889 if (tracker->dirty() && !ShouldKeepDirty(*tracker)) { | 889 if (tracker->dirty() && !ShouldKeepDirty(*tracker)) { |
890 tracker->set_dirty(false); | 890 tracker->set_dirty(false); |
891 dirty_trackers_.erase(tracker); | 891 dirty_trackers_.erase(tracker); |
892 } | 892 } |
893 PutTrackerToBatch(*tracker, batch.get()); | 893 PutTrackerToBatch(*tracker, batch.get()); |
894 | 894 |
895 WriteToDatabase(batch.Pass(), callback); | 895 WriteToDatabase(batch.Pass(), callback); |
896 } | 896 } |
897 | 897 |
| 898 bool MetadataDatabase::GetNormalPriorityDirtyTracker(FileTracker* tracker) { |
| 899 // TODO(tzik): Split |dirty_trackers| to |normal_priority_dirty_trackers| |
| 900 // and |low_priority_dirty_trackers|. |
| 901 // Add a function to mark a dirty tracker low priority. |
| 902 NOTIMPLEMENTED(); |
| 903 return false; |
| 904 } |
| 905 |
| 906 bool MetadataDatabase::GetLowPriorityDirtyTracker(FileTracker* tracker) { |
| 907 NOTIMPLEMENTED(); |
| 908 return false; |
| 909 } |
| 910 |
| 911 void MetadataDatabase::ResolveTrivialDirtiness( |
| 912 int64 tracker_id, |
| 913 const SyncStatusCallback& callback) { |
| 914 NOTIMPLEMENTED(); |
| 915 callback.Run(SYNC_STATUS_FAILED); |
| 916 } |
| 917 |
898 MetadataDatabase::MetadataDatabase(base::SequencedTaskRunner* task_runner) | 918 MetadataDatabase::MetadataDatabase(base::SequencedTaskRunner* task_runner) |
899 : task_runner_(task_runner), weak_ptr_factory_(this) { | 919 : task_runner_(task_runner), weak_ptr_factory_(this) { |
900 DCHECK(task_runner); | 920 DCHECK(task_runner); |
901 } | 921 } |
902 | 922 |
903 // static | 923 // static |
904 void MetadataDatabase::CreateOnTaskRunner( | 924 void MetadataDatabase::CreateOnTaskRunner( |
905 base::SingleThreadTaskRunner* callback_runner, | 925 base::SingleThreadTaskRunner* callback_runner, |
906 base::SequencedTaskRunner* task_runner, | 926 base::SequencedTaskRunner* task_runner, |
907 const base::FilePath& database_path, | 927 const base::FilePath& database_path, |
(...skipping 557 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1465 FROM_HERE, | 1485 FROM_HERE, |
1466 base::Bind(&leveldb::DB::Write, | 1486 base::Bind(&leveldb::DB::Write, |
1467 base::Unretained(db_.get()), | 1487 base::Unretained(db_.get()), |
1468 leveldb::WriteOptions(), | 1488 leveldb::WriteOptions(), |
1469 base::Owned(batch.release())), | 1489 base::Owned(batch.release())), |
1470 base::Bind(&AdaptLevelDBStatusToSyncStatusCode, callback)); | 1490 base::Bind(&AdaptLevelDBStatusToSyncStatusCode, callback)); |
1471 } | 1491 } |
1472 | 1492 |
1473 } // namespace drive_backend | 1493 } // namespace drive_backend |
1474 } // namespace sync_file_system | 1494 } // namespace sync_file_system |
OLD | NEW |