| 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 #ifndef CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_METADATA_DATABASE_H_ | 5 #ifndef CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_METADATA_DATABASE_H_ |
| 6 #define CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_METADATA_DATABASE_H_ | 6 #define CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_METADATA_DATABASE_H_ |
| 7 | 7 |
| 8 #include <map> | 8 #include <map> |
| 9 #include <set> | 9 #include <set> |
| 10 #include <string> | 10 #include <string> |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 42 namespace tracked_objects { | 42 namespace tracked_objects { |
| 43 class Location; | 43 class Location; |
| 44 } | 44 } |
| 45 | 45 |
| 46 namespace sync_file_system { | 46 namespace sync_file_system { |
| 47 namespace drive_backend { | 47 namespace drive_backend { |
| 48 | 48 |
| 49 class FileDetails; | 49 class FileDetails; |
| 50 class FileMetadata; | 50 class FileMetadata; |
| 51 class FileTracker; | 51 class FileTracker; |
| 52 class MetadataDatabaseIndex; |
| 52 class ServiceMetadata; | 53 class ServiceMetadata; |
| 53 | 54 |
| 54 struct DatabaseContents { | 55 struct DatabaseContents { |
| 55 scoped_ptr<ServiceMetadata> service_metadata; | 56 scoped_ptr<ServiceMetadata> service_metadata; |
| 56 ScopedVector<FileMetadata> file_metadata; | 57 ScopedVector<FileMetadata> file_metadata; |
| 57 ScopedVector<FileTracker> file_trackers; | 58 ScopedVector<FileTracker> file_trackers; |
| 58 | 59 |
| 59 DatabaseContents(); | 60 DatabaseContents(); |
| 60 ~DatabaseContents(); | 61 ~DatabaseContents(); |
| 61 }; | 62 }; |
| (...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 113 // - have |needs_folder_listing| flag and dirty flag, or | 114 // - have |needs_folder_listing| flag and dirty flag, or |
| 114 // - have all children at the stored largest change ID. | 115 // - have all children at the stored largest change ID. |
| 115 // | 116 // |
| 116 // - If multiple trackers have the same parent tracker and same title, they | 117 // - If multiple trackers have the same parent tracker and same title, they |
| 117 // must not have same |file_id|, and at most one of them may be active. | 118 // must not have same |file_id|, and at most one of them may be active. |
| 118 // - If multiple trackers have the same |file_id|, at most one of them may be | 119 // - If multiple trackers have the same |file_id|, at most one of them may be |
| 119 // active. | 120 // active. |
| 120 // | 121 // |
| 121 class MetadataDatabase { | 122 class MetadataDatabase { |
| 122 public: | 123 public: |
| 123 typedef base::ScopedPtrHashMap<std::string, FileMetadata> MetadataByID; | |
| 124 typedef base::ScopedPtrHashMap<int64, FileTracker> TrackerByID; | |
| 125 typedef base::hash_map<std::string, TrackerIDSet> TrackerIDsByFileID; | |
| 126 typedef base::hash_map<std::string, TrackerIDSet> TrackerIDsByTitle; | |
| 127 typedef std::map<int64, TrackerIDsByTitle> TrackerIDsByParentAndTitle; | |
| 128 typedef base::hash_map<std::string, int64> TrackerIDByAppID; | |
| 129 typedef std::vector<std::string> FileIDList; | 124 typedef std::vector<std::string> FileIDList; |
| 130 | 125 |
| 131 typedef base::Callback< | 126 typedef base::Callback< |
| 132 void(SyncStatusCode status, scoped_ptr<MetadataDatabase> instance)> | 127 void(SyncStatusCode status, scoped_ptr<MetadataDatabase> instance)> |
| 133 CreateCallback; | 128 CreateCallback; |
| 134 | 129 |
| 135 enum ActivationStatus { | 130 enum ActivationStatus { |
| 136 ACTIVATION_PENDING, | 131 ACTIVATION_PENDING, |
| 137 ACTIVATION_FAILED_ANOTHER_ACTIVE_TRACKER, | 132 ACTIVATION_FAILED_ANOTHER_ACTIVE_TRACKER, |
| 138 }; | 133 }; |
| (...skipping 214 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 353 bool GetMultiParentFileTrackers(std::string* file_id, | 348 bool GetMultiParentFileTrackers(std::string* file_id, |
| 354 TrackerIDSet* trackers); | 349 TrackerIDSet* trackers); |
| 355 bool GetConflictingTrackers(TrackerIDSet* trackers); | 350 bool GetConflictingTrackers(TrackerIDSet* trackers); |
| 356 | 351 |
| 357 // Sets |app_ids| to a list of all registered app ids. | 352 // Sets |app_ids| to a list of all registered app ids. |
| 358 void GetRegisteredAppIDs(std::vector<std::string>* app_ids); | 353 void GetRegisteredAppIDs(std::vector<std::string>* app_ids); |
| 359 | 354 |
| 360 private: | 355 private: |
| 361 friend class MetadataDatabaseTest; | 356 friend class MetadataDatabaseTest; |
| 362 | 357 |
| 363 struct DirtyTrackerComparator { | |
| 364 bool operator()(const FileTracker* left, | |
| 365 const FileTracker* right) const; | |
| 366 }; | |
| 367 | |
| 368 typedef std::set<FileTracker*, DirtyTrackerComparator> DirtyTrackers; | |
| 369 | |
| 370 MetadataDatabase(base::SequencedTaskRunner* task_runner, | 358 MetadataDatabase(base::SequencedTaskRunner* task_runner, |
| 371 const base::FilePath& database_path, | 359 const base::FilePath& database_path, |
| 372 leveldb::Env* env_override); | 360 leveldb::Env* env_override); |
| 373 static void CreateOnTaskRunner(base::SingleThreadTaskRunner* callback_runner, | 361 static void CreateOnTaskRunner(base::SingleThreadTaskRunner* callback_runner, |
| 374 base::SequencedTaskRunner* task_runner, | 362 base::SequencedTaskRunner* task_runner, |
| 375 const base::FilePath& database_path, | 363 const base::FilePath& database_path, |
| 376 leveldb::Env* env_override, | 364 leveldb::Env* env_override, |
| 377 const CreateCallback& callback); | 365 const CreateCallback& callback); |
| 378 SyncStatusCode InitializeOnTaskRunner(); | 366 SyncStatusCode InitializeOnTaskRunner(); |
| 379 void BuildIndexes(DatabaseContents* contents); | 367 void BuildIndexes(DatabaseContents* contents); |
| 380 | 368 |
| 381 // Database manipulation methods. | 369 // Database manipulation methods. |
| 382 void RegisterTrackerAsAppRoot(const std::string& app_id, | 370 void RegisterTrackerAsAppRoot(const std::string& app_id, |
| 383 int64 tracker_id, | 371 int64 tracker_id, |
| 384 leveldb::WriteBatch* batch); | 372 leveldb::WriteBatch* batch); |
| 385 void MakeTrackerActive(int64 tracker_id, leveldb::WriteBatch* batch); | |
| 386 void MakeTrackerInactive(int64 tracker_id, leveldb::WriteBatch* batch); | |
| 387 void MakeAppRootDisabled(int64 tracker_id, leveldb::WriteBatch* batch); | |
| 388 void MakeAppRootEnabled(int64 tracker_id, leveldb::WriteBatch* batch); | |
| 389 | |
| 390 void UnregisterTrackerAsAppRoot(const std::string& app_id, | |
| 391 leveldb::WriteBatch* batch); | |
| 392 void RemoveAllDescendantTrackers(int64 root_tracker_id, | |
| 393 leveldb::WriteBatch* batch); | |
| 394 | 373 |
| 395 void CreateTrackerForParentAndFileID(const FileTracker& parent_tracker, | 374 void CreateTrackerForParentAndFileID(const FileTracker& parent_tracker, |
| 396 const std::string& file_id, | 375 const std::string& file_id, |
| 397 leveldb::WriteBatch* batch); | 376 leveldb::WriteBatch* batch); |
| 398 void CreateTrackerForParentAndFileMetadata(const FileTracker& parent_tracker, | 377 void CreateTrackerForParentAndFileMetadata(const FileTracker& parent_tracker, |
| 399 const FileMetadata& file_metadata, | 378 const FileMetadata& file_metadata, |
| 400 UpdateOption option, | 379 UpdateOption option, |
| 401 leveldb::WriteBatch* batch); | 380 leveldb::WriteBatch* batch); |
| 402 void CreateTrackerInternal(const FileTracker& parent_tracker, | 381 void CreateTrackerInternal(const FileTracker& parent_tracker, |
| 403 const std::string& file_id, | 382 const std::string& file_id, |
| 404 const FileDetails* details, | 383 const FileDetails* details, |
| 405 UpdateOption option, | 384 UpdateOption option, |
| 406 leveldb::WriteBatch* batch); | 385 leveldb::WriteBatch* batch); |
| 407 | 386 |
| 408 void RemoveTracker(int64 tracker_id, leveldb::WriteBatch* batch); | |
| 409 void RemoveTrackerIgnoringSameTitle(int64 tracker_id, | |
| 410 leveldb::WriteBatch* batch); | |
| 411 void RemoveTrackerInternal(int64 tracker_id, | |
| 412 leveldb::WriteBatch* batch, | |
| 413 bool ignoring_same_title); | |
| 414 void MaybeAddTrackersForNewFile(const FileMetadata& file, | 387 void MaybeAddTrackersForNewFile(const FileMetadata& file, |
| 415 UpdateOption option, | 388 UpdateOption option, |
| 416 leveldb::WriteBatch* batch); | 389 leveldb::WriteBatch* batch); |
| 417 | 390 |
| 418 void MarkSingleTrackerAsDirty(FileTracker* tracker, | |
| 419 leveldb::WriteBatch* batch); | |
| 420 void ClearDirty(FileTracker* tracker, leveldb::WriteBatch* batch); | |
| 421 void MarkTrackerSetDirty(TrackerIDSet* trackers, | |
| 422 leveldb::WriteBatch* batch); | |
| 423 void MarkTrackersDirtyByFileID(const std::string& file_id, | |
| 424 leveldb::WriteBatch* batch); | |
| 425 void MarkTrackersDirtyByPath(int64 parent_tracker_id, | |
| 426 const std::string& title, | |
| 427 leveldb::WriteBatch* batch); | |
| 428 | |
| 429 void EraseTrackerFromFileIDIndex(FileTracker* tracker, | |
| 430 leveldb::WriteBatch* batch); | |
| 431 void EraseTrackerFromPathIndex(FileTracker* tracker); | |
| 432 void EraseFileFromDatabase(const std::string& file_id, | |
| 433 leveldb::WriteBatch* batch); | |
| 434 | |
| 435 int64 IncrementTrackerID(leveldb::WriteBatch* batch); | 391 int64 IncrementTrackerID(leveldb::WriteBatch* batch); |
| 436 | 392 |
| 437 void RecursiveMarkTrackerAsDirty(int64 root_tracker_id, | |
| 438 leveldb::WriteBatch* batch); | |
| 439 bool CanActivateTracker(const FileTracker& tracker); | 393 bool CanActivateTracker(const FileTracker& tracker); |
| 440 bool ShouldKeepDirty(const FileTracker& tracker) const; | 394 bool ShouldKeepDirty(const FileTracker& tracker) const; |
| 441 | 395 |
| 442 bool HasDisabledAppRoot(const FileTracker& tracker) const; | 396 bool HasDisabledAppRoot(const FileTracker& tracker) const; |
| 443 bool HasActiveTrackerForFileID(const std::string& file_id) const; | 397 bool HasActiveTrackerForFileID(const std::string& file_id) const; |
| 444 bool HasActiveTrackerForPath(int64 parent_tracker, | 398 bool HasActiveTrackerForPath(int64 parent_tracker, |
| 445 const std::string& title) const; | 399 const std::string& title) const; |
| 446 | 400 |
| 447 void RemoveUnneededTrackersForMissingFile(const std::string& file_id, | 401 void RemoveUnneededTrackersForMissingFile(const std::string& file_id, |
| 448 leveldb::WriteBatch* batch); | 402 leveldb::WriteBatch* batch); |
| 449 void UpdateByFileMetadata(const tracked_objects::Location& from_where, | 403 void UpdateByFileMetadata(const tracked_objects::Location& from_where, |
| 450 scoped_ptr<FileMetadata> file, | 404 scoped_ptr<FileMetadata> file, |
| 451 UpdateOption option, | 405 UpdateOption option, |
| 452 leveldb::WriteBatch* batch); | 406 leveldb::WriteBatch* batch); |
| 453 | 407 |
| 454 void WriteToDatabase(scoped_ptr<leveldb::WriteBatch> batch, | 408 void WriteToDatabase(scoped_ptr<leveldb::WriteBatch> batch, |
| 455 const SyncStatusCallback& callback); | 409 const SyncStatusCallback& callback); |
| 456 | 410 |
| 457 bool HasNewerFileMetadata(const std::string& file_id, int64 change_id); | 411 bool HasNewerFileMetadata(const std::string& file_id, int64 change_id); |
| 458 | 412 |
| 459 scoped_ptr<base::ListValue> DumpTrackers(); | 413 scoped_ptr<base::ListValue> DumpTrackers(); |
| 460 scoped_ptr<base::ListValue> DumpMetadata(); | 414 scoped_ptr<base::ListValue> DumpMetadata(); |
| 461 | 415 |
| 462 void StoreFileMetadata(scoped_ptr<FileMetadata> file_metadata); | |
| 463 void StoreFileTracker(scoped_ptr<FileTracker> file_tracker); | |
| 464 | |
| 465 void AttachSyncRoot(const google_apis::FileResource& sync_root_folder, | 416 void AttachSyncRoot(const google_apis::FileResource& sync_root_folder, |
| 466 leveldb::WriteBatch* batch); | 417 leveldb::WriteBatch* batch); |
| 467 void AttachInitialAppRoot(const google_apis::FileResource& app_root_folder, | 418 void AttachInitialAppRoot(const google_apis::FileResource& app_root_folder, |
| 468 leveldb::WriteBatch* batch); | 419 leveldb::WriteBatch* batch); |
| 469 void InsertFileTrackerToIndex(FileTracker* tracker); | |
| 470 | 420 |
| 471 void ForceActivateTrackerByPath(int64 parent_tracker_id, | 421 void ForceActivateTrackerByPath(int64 parent_tracker_id, |
| 472 const std::string& title, | 422 const std::string& title, |
| 473 const std::string& file_id, | 423 const std::string& file_id, |
| 474 leveldb::WriteBatch* batch); | 424 leveldb::WriteBatch* batch); |
| 475 | 425 |
| 476 scoped_refptr<base::SequencedTaskRunner> task_runner_; | 426 scoped_refptr<base::SequencedTaskRunner> task_runner_; |
| 477 base::FilePath database_path_; | 427 base::FilePath database_path_; |
| 478 leveldb::Env* env_override_; | 428 leveldb::Env* env_override_; |
| 479 scoped_ptr<leveldb::DB> db_; | 429 scoped_ptr<leveldb::DB> db_; |
| 480 | 430 |
| 481 scoped_ptr<ServiceMetadata> service_metadata_; | 431 scoped_ptr<ServiceMetadata> service_metadata_; |
| 482 int64 largest_known_change_id_; | 432 int64 largest_known_change_id_; |
| 483 | 433 |
| 484 MetadataByID metadata_by_id_; // Owned. | 434 scoped_ptr<MetadataDatabaseIndex> index_; |
| 485 TrackerByID tracker_by_id_; // Owned. | |
| 486 | |
| 487 // Maps FileID to trackers. The active tracker must be unique per FileID. | |
| 488 // This must be updated when updating |active| field of a tracker. | |
| 489 TrackerIDsByFileID trackers_by_file_id_; // Not owned. | |
| 490 | |
| 491 // Maps AppID to the app-root tracker. | |
| 492 // This must be updated when a tracker is registered/unregistered as an | |
| 493 // app-root. | |
| 494 TrackerIDByAppID app_root_by_app_id_; // Not owned. | |
| 495 | |
| 496 // Maps |tracker_id| to its children grouped by their |title|. | |
| 497 // If the title is unknown for a tracker, treats its title as empty. Empty | |
| 498 // titled file must not be active. | |
| 499 // The active tracker must be unique per its parent_tracker and its title. | |
| 500 // This must be updated when updating |title|, |active| or | |
| 501 // |parent_tracker_id|. | |
| 502 TrackerIDsByParentAndTitle trackers_by_parent_and_title_; | |
| 503 | |
| 504 // Holds all trackers which marked as dirty. | |
| 505 // This must be updated when updating |dirty| field of a tracker. | |
| 506 DirtyTrackers dirty_trackers_; // Not owned. | |
| 507 DirtyTrackers low_priority_dirty_trackers_; // Not owned. | |
| 508 | 435 |
| 509 base::WeakPtrFactory<MetadataDatabase> weak_ptr_factory_; | 436 base::WeakPtrFactory<MetadataDatabase> weak_ptr_factory_; |
| 510 | 437 |
| 511 DISALLOW_COPY_AND_ASSIGN(MetadataDatabase); | 438 DISALLOW_COPY_AND_ASSIGN(MetadataDatabase); |
| 512 }; | 439 }; |
| 513 | 440 |
| 514 } // namespace drive_backend | 441 } // namespace drive_backend |
| 515 } // namespace sync_file_system | 442 } // namespace sync_file_system |
| 516 | 443 |
| 517 #endif // CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_METADATA_DATABASE_H_ | 444 #endif // CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_METADATA_DATABASE_H_ |
| OLD | NEW |