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_file_sync_service.h" | 5 #include "chrome/browser/sync_file_system/drive_file_sync_service.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "base/message_loop.h" | 9 #include "base/message_loop.h" |
10 #include "base/message_loop_proxy.h" | 10 #include "base/message_loop_proxy.h" |
(...skipping 169 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
180 typedef DriveFileSyncService::ChangeQueueItem ChangeQueueItem; | 180 typedef DriveFileSyncService::ChangeQueueItem ChangeQueueItem; |
181 typedef DriveFileSyncService::RemoteSyncType RemoteSyncType; | 181 typedef DriveFileSyncService::RemoteSyncType RemoteSyncType; |
182 sync_service_->pending_changes_.clear(); | 182 sync_service_->pending_changes_.clear(); |
183 | 183 |
184 RemoteSyncType sync_type = DriveFileSyncService::REMOTE_SYNC_TYPE_BATCH; | 184 RemoteSyncType sync_type = DriveFileSyncService::REMOTE_SYNC_TYPE_BATCH; |
185 std::pair<iterator, bool> inserted_to_queue = | 185 std::pair<iterator, bool> inserted_to_queue = |
186 sync_service_->pending_changes_.insert( | 186 sync_service_->pending_changes_.insert( |
187 ChangeQueueItem(changestamp, sync_type, url)); | 187 ChangeQueueItem(changestamp, sync_type, url)); |
188 DCHECK(inserted_to_queue.second); | 188 DCHECK(inserted_to_queue.second); |
189 | 189 |
190 DriveFileSyncService::PathToChange* path_to_change = | 190 DriveFileSyncService::PathToChangeMap* path_to_change = |
191 &sync_service_->url_to_change_[url.origin()]; | 191 &sync_service_->origin_to_changes_map_[url.origin()]; |
192 (*path_to_change)[url.path()] = DriveFileSyncService::RemoteChange( | 192 (*path_to_change)[url.path()] = DriveFileSyncService::RemoteChange( |
193 changestamp, resource_id, sync_type, url, file_change, | 193 changestamp, resource_id, sync_type, url, file_change, |
194 inserted_to_queue.first); | 194 inserted_to_queue.first); |
195 } | 195 } |
196 | 196 |
197 DriveFileSyncClient* sync_client() { | 197 DriveFileSyncClient* sync_client() { |
198 if (sync_client_) | 198 if (sync_client_) |
199 return sync_client_.get(); | 199 return sync_client_.get(); |
200 return sync_service_->sync_client_.get(); | 200 return sync_service_->sync_client_.get(); |
201 } | 201 } |
(...skipping 339 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
541 google_apis::HTTP_SUCCESS, | 541 google_apis::HTTP_SUCCESS, |
542 base::Passed(&listing_files_in_empty_directory))); | 542 base::Passed(&listing_files_in_empty_directory))); |
543 | 543 |
544 SetUpDriveSyncService(); | 544 SetUpDriveSyncService(); |
545 bool done = false; | 545 bool done = false; |
546 sync_service()->RegisterOriginForTrackingChanges( | 546 sync_service()->RegisterOriginForTrackingChanges( |
547 kOrigin, base::Bind(&ExpectEqStatus, &done, fileapi::SYNC_STATUS_OK)); | 547 kOrigin, base::Bind(&ExpectEqStatus, &done, fileapi::SYNC_STATUS_OK)); |
548 message_loop()->RunUntilIdle(); | 548 message_loop()->RunUntilIdle(); |
549 EXPECT_TRUE(done); | 549 EXPECT_TRUE(done); |
550 | 550 |
551 EXPECT_EQ(1u, metadata_store()->batch_sync_origins().size()); | 551 EXPECT_TRUE(metadata_store()->batch_sync_origins().empty()); |
552 EXPECT_TRUE(metadata_store()->incremental_sync_origins().empty()); | 552 EXPECT_EQ(1u, metadata_store()->incremental_sync_origins().size()); |
553 EXPECT_TRUE(pending_changes().empty()); | 553 EXPECT_TRUE(pending_changes().empty()); |
554 } | 554 } |
555 | 555 |
556 TEST_F(DriveFileSyncServiceTest, RegisterExistingOrigin) { | 556 TEST_F(DriveFileSyncServiceTest, RegisterExistingOrigin) { |
557 const GURL kOrigin("chrome-extension://example"); | 557 const GURL kOrigin("chrome-extension://example"); |
558 const std::string kDirectoryResourceId("folder:origin_directory_resource_id"); | 558 const std::string kDirectoryResourceId("folder:origin_directory_resource_id"); |
559 const std::string kSyncRootResourceId("folder:sync_root_resource_id"); | 559 const std::string kSyncRootResourceId("folder:sync_root_resource_id"); |
560 | 560 |
561 metadata_store()->SetSyncRootDirectory(kSyncRootResourceId); | 561 metadata_store()->SetSyncRootDirectory(kSyncRootResourceId); |
562 | 562 |
(...skipping 372 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
935 *LoadJSONFile("gdata/file_entry.json"))); | 935 *LoadJSONFile("gdata/file_entry.json"))); |
936 AppendIncrementalRemoteChange(kOrigin, *entry, 12345); | 936 AppendIncrementalRemoteChange(kOrigin, *entry, 12345); |
937 ProcessRemoteChange(fileapi::SYNC_STATUS_OK, | 937 ProcessRemoteChange(fileapi::SYNC_STATUS_OK, |
938 CreateURL(kOrigin, kFileName), | 938 CreateURL(kOrigin, kFileName), |
939 fileapi::SYNC_OPERATION_UPDATED); | 939 fileapi::SYNC_OPERATION_UPDATED); |
940 } | 940 } |
941 | 941 |
942 #endif // !defined(OS_ANDROID) | 942 #endif // !defined(OS_ANDROID) |
943 | 943 |
944 } // namespace sync_file_system | 944 } // namespace sync_file_system |
OLD | NEW |