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 |