| 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 <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/files/file_path.h" | 9 #include "base/files/file_path.h" |
| 10 #include "base/files/scoped_temp_dir.h" | 10 #include "base/files/scoped_temp_dir.h" |
| (...skipping 15 matching lines...) Expand all Loading... |
| 26 | 26 |
| 27 #define FPL FILE_PATH_LITERAL | 27 #define FPL FILE_PATH_LITERAL |
| 28 | 28 |
| 29 using content::BrowserThread; | 29 using content::BrowserThread; |
| 30 | 30 |
| 31 namespace sync_file_system { | 31 namespace sync_file_system { |
| 32 | 32 |
| 33 namespace { | 33 namespace { |
| 34 | 34 |
| 35 const char kOrigin[] = "chrome-extension://example"; | 35 const char kOrigin[] = "chrome-extension://example"; |
| 36 const char* const kServiceName = DriveFileSyncService::kServiceName; | |
| 37 | 36 |
| 38 typedef DriveMetadataStore::ResourceIdByOrigin ResourceIdByOrigin; | 37 typedef DriveMetadataStore::ResourceIdByOrigin ResourceIdByOrigin; |
| 39 typedef DriveMetadataStore::OriginByResourceId OriginByResourceId; | 38 typedef DriveMetadataStore::OriginByResourceId OriginByResourceId; |
| 40 | 39 |
| 41 fileapi::FileSystemURL URL(const base::FilePath& path) { | 40 fileapi::FileSystemURL URL(const base::FilePath& path) { |
| 42 return CreateSyncableFileSystemURL(GURL(kOrigin), kServiceName, path); | 41 return CreateSyncableFileSystemURL(GURL(kOrigin), path); |
| 43 } | 42 } |
| 44 | 43 |
| 45 std::string GetResourceID(const ResourceIdByOrigin& sync_origins, | 44 std::string GetResourceID(const ResourceIdByOrigin& sync_origins, |
| 46 const GURL& origin) { | 45 const GURL& origin) { |
| 47 ResourceIdByOrigin::const_iterator itr = sync_origins.find(origin); | 46 ResourceIdByOrigin::const_iterator itr = sync_origins.find(origin); |
| 48 if (itr == sync_origins.end()) | 47 if (itr == sync_origins.end()) |
| 49 return std::string(); | 48 return std::string(); |
| 50 return itr->second; | 49 return itr->second; |
| 51 } | 50 } |
| 52 | 51 |
| (...skipping 19 matching lines...) Expand all Loading... |
| 72 virtual ~DriveMetadataStoreTest() {} | 71 virtual ~DriveMetadataStoreTest() {} |
| 73 | 72 |
| 74 virtual void SetUp() OVERRIDE { | 73 virtual void SetUp() OVERRIDE { |
| 75 file_thread_.reset(new base::Thread("Thread_File")); | 74 file_thread_.reset(new base::Thread("Thread_File")); |
| 76 file_thread_->Start(); | 75 file_thread_->Start(); |
| 77 | 76 |
| 78 ui_task_runner_ = base::MessageLoopProxy::current(); | 77 ui_task_runner_ = base::MessageLoopProxy::current(); |
| 79 file_task_runner_ = file_thread_->message_loop_proxy(); | 78 file_task_runner_ = file_thread_->message_loop_proxy(); |
| 80 | 79 |
| 81 ASSERT_TRUE(base_dir_.CreateUniqueTempDir()); | 80 ASSERT_TRUE(base_dir_.CreateUniqueTempDir()); |
| 82 ASSERT_TRUE(RegisterSyncableFileSystem(kServiceName)); | 81 RegisterSyncableFileSystem(); |
| 83 } | 82 } |
| 84 | 83 |
| 85 virtual void TearDown() OVERRIDE { | 84 virtual void TearDown() OVERRIDE { |
| 86 EXPECT_TRUE(RevokeSyncableFileSystem(kServiceName)); | 85 RevokeSyncableFileSystem(); |
| 87 | 86 |
| 88 DropDatabase(); | 87 DropDatabase(); |
| 89 file_thread_->Stop(); | 88 file_thread_->Stop(); |
| 90 message_loop_.RunUntilIdle(); | 89 message_loop_.RunUntilIdle(); |
| 91 } | 90 } |
| 92 | 91 |
| 93 protected: | 92 protected: |
| 94 void InitializeDatabase() { | 93 void InitializeDatabase() { |
| 95 EXPECT_TRUE(ui_task_runner_->RunsTasksOnCurrentThread()); | 94 EXPECT_TRUE(ui_task_runner_->RunsTasksOnCurrentThread()); |
| 96 | 95 |
| (...skipping 411 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 508 metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1); | 507 metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1); |
| 509 metadata_store()->AddIncrementalSyncOrigin(kOrigin2, kResourceId2); | 508 metadata_store()->AddIncrementalSyncOrigin(kOrigin2, kResourceId2); |
| 510 metadata_store()->AddIncrementalSyncOrigin(kOrigin3, kResourceId3); | 509 metadata_store()->AddIncrementalSyncOrigin(kOrigin3, kResourceId3); |
| 511 DisableOrigin(kOrigin3); | 510 DisableOrigin(kOrigin3); |
| 512 EXPECT_EQ(2u, metadata_store()->incremental_sync_origins().size()); | 511 EXPECT_EQ(2u, metadata_store()->incremental_sync_origins().size()); |
| 513 EXPECT_EQ(1u, metadata_store()->disabled_origins().size()); | 512 EXPECT_EQ(1u, metadata_store()->disabled_origins().size()); |
| 514 | 513 |
| 515 EXPECT_EQ(SYNC_STATUS_OK, | 514 EXPECT_EQ(SYNC_STATUS_OK, |
| 516 UpdateEntry( | 515 UpdateEntry( |
| 517 CreateSyncableFileSystemURL( | 516 CreateSyncableFileSystemURL( |
| 518 kOrigin1, kServiceName, base::FilePath(FPL("guf"))), | 517 kOrigin1, base::FilePath(FPL("guf"))), |
| 519 CreateMetadata("foo", "spam", false, false))); | 518 CreateMetadata("foo", "spam", false, false))); |
| 520 EXPECT_EQ(SYNC_STATUS_OK, | 519 EXPECT_EQ(SYNC_STATUS_OK, |
| 521 UpdateEntry( | 520 UpdateEntry( |
| 522 CreateSyncableFileSystemURL( | 521 CreateSyncableFileSystemURL( |
| 523 kOrigin2, kServiceName, base::FilePath(FPL("mof"))), | 522 kOrigin2, base::FilePath(FPL("mof"))), |
| 524 CreateMetadata("bar", "ham", false, false))); | 523 CreateMetadata("bar", "ham", false, false))); |
| 525 EXPECT_EQ(SYNC_STATUS_OK, | 524 EXPECT_EQ(SYNC_STATUS_OK, |
| 526 UpdateEntry( | 525 UpdateEntry( |
| 527 CreateSyncableFileSystemURL( | 526 CreateSyncableFileSystemURL( |
| 528 kOrigin3, kServiceName, base::FilePath(FPL("waf"))), | 527 kOrigin3, base::FilePath(FPL("waf"))), |
| 529 CreateMetadata("baz", "egg", false, false))); | 528 CreateMetadata("baz", "egg", false, false))); |
| 530 | 529 |
| 531 EXPECT_EQ(SYNC_STATUS_OK, RemoveOrigin(kOrigin2)); | 530 EXPECT_EQ(SYNC_STATUS_OK, RemoveOrigin(kOrigin2)); |
| 532 EXPECT_EQ(SYNC_STATUS_OK, RemoveOrigin(kOrigin3)); | 531 EXPECT_EQ(SYNC_STATUS_OK, RemoveOrigin(kOrigin3)); |
| 533 | 532 |
| 534 DropDatabase(); | 533 DropDatabase(); |
| 535 InitializeDatabase(); | 534 InitializeDatabase(); |
| 536 | 535 |
| 537 // kOrigin1 should be the only one left. | 536 // kOrigin1 should be the only one left. |
| 538 EXPECT_EQ(1u, metadata_store()->incremental_sync_origins().size()); | 537 EXPECT_EQ(1u, metadata_store()->incremental_sync_origins().size()); |
| (...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 602 metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1); | 601 metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1); |
| 603 VerifyIncrementalSyncOrigin(kOrigin1, kResourceId1); | 602 VerifyIncrementalSyncOrigin(kOrigin1, kResourceId1); |
| 604 VerifyReverseMap(); | 603 VerifyReverseMap(); |
| 605 | 604 |
| 606 metadata_store()->SetOriginRootDirectory(kOrigin1, kResourceId2); | 605 metadata_store()->SetOriginRootDirectory(kOrigin1, kResourceId2); |
| 607 VerifyIncrementalSyncOrigin(kOrigin1, kResourceId2); | 606 VerifyIncrementalSyncOrigin(kOrigin1, kResourceId2); |
| 608 VerifyReverseMap(); | 607 VerifyReverseMap(); |
| 609 } | 608 } |
| 610 | 609 |
| 611 } // namespace sync_file_system | 610 } // namespace sync_file_system |
| OLD | NEW |