Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(34)

Side by Side Diff: chrome/browser/sync_file_system/drive_backend/sync_engine_unittest.cc

Issue 306813002: [SyncFS] Make routines using metadata database async (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Remove needless method Created 6 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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/sync_engine.h" 5 #include "chrome/browser/sync_file_system/drive_backend/sync_engine.h"
6 6
7 #include "base/files/scoped_temp_dir.h" 7 #include "base/files/scoped_temp_dir.h"
8 #include "base/run_loop.h" 8 #include "base/run_loop.h"
9 #include "base/strings/stringprintf.h" 9 #include "base/strings/stringprintf.h"
10 #include "chrome/browser/drive/drive_uploader.h" 10 #include "chrome/browser/drive/drive_uploader.h"
(...skipping 118 matching lines...) Expand 10 before | Expand all | Expand 10 after
129 virtual void TearDown() OVERRIDE { 129 virtual void TearDown() OVERRIDE {
130 sync_engine_.reset(); 130 sync_engine_.reset();
131 extension_service_.reset(); 131 extension_service_.reset();
132 base::RunLoop().RunUntilIdle(); 132 base::RunLoop().RunUntilIdle();
133 } 133 }
134 134
135 MockExtensionService* extension_service() { return extension_service_.get(); } 135 MockExtensionService* extension_service() { return extension_service_.get(); }
136 SyncEngine* sync_engine() { return sync_engine_.get(); } 136 SyncEngine* sync_engine() { return sync_engine_.get(); }
137 137
138 void UpdateRegisteredApps() { 138 void UpdateRegisteredApps() {
139 sync_engine_->UpdateRegisteredApps(); 139 sync_engine_->UpdateRegisteredAppsForTesting();
140 } 140 }
141 141
142 SyncTaskManager* GetSyncEngineTaskManager() { 142 SyncTaskManager* GetSyncEngineTaskManager() {
143 return sync_engine_->GetSyncTaskManagerForTesting(); 143 return sync_engine_->GetSyncTaskManagerForTesting();
144 } 144 }
145 145
146 void CheckServiceState(SyncStatusCode expected_sync_status, 146 void CheckServiceState(SyncStatusCode expected_sync_status,
147 RemoteServiceState expected_service_status, 147 RemoteServiceState expected_service_status,
148 SyncStatusCode sync_status) { 148 SyncStatusCode sync_status) {
149 EXPECT_EQ(expected_sync_status, sync_status); 149 EXPECT_EQ(expected_sync_status, sync_status);
150 EXPECT_EQ(expected_service_status, sync_engine_->GetCurrentState()); 150 EXPECT_EQ(expected_service_status, sync_engine_->GetCurrentState());
151 } 151 }
152 152
153 private: 153 private:
154 content::TestBrowserThreadBundle browser_threads_; 154 content::TestBrowserThreadBundle browser_threads_;
155 base::ScopedTempDir profile_dir_; 155 base::ScopedTempDir profile_dir_;
156 scoped_ptr<leveldb::Env> in_memory_env_; 156 scoped_ptr<leveldb::Env> in_memory_env_;
157 157
158 scoped_ptr<MockExtensionService> extension_service_; 158 scoped_ptr<MockExtensionService> extension_service_;
159 scoped_ptr<drive_backend::SyncEngine> sync_engine_; 159 scoped_ptr<drive_backend::SyncEngine> sync_engine_;
160 160
161 DISALLOW_COPY_AND_ASSIGN(SyncEngineTest); 161 DISALLOW_COPY_AND_ASSIGN(SyncEngineTest);
162 }; 162 };
163 163
164 TEST_F(SyncEngineTest, EnableOrigin) { 164 TEST_F(SyncEngineTest, EnableOrigin) {
165 FileTracker tracker; 165 FileTracker tracker;
166 SyncStatusCode sync_status = SYNC_STATUS_UNKNOWN; 166 SyncStatusCode sync_status = SYNC_STATUS_UNKNOWN;
167 MetadataDatabase* metadata_database = sync_engine()->GetMetadataDatabase(); 167 MetadataDatabase* metadata_database =
168 sync_engine()->GetMetadataDatabaseForTesting();
168 GURL origin = extensions::Extension::GetBaseURLFromExtensionId(kAppID); 169 GURL origin = extensions::Extension::GetBaseURLFromExtensionId(kAppID);
169 170
170 sync_engine()->RegisterOrigin(origin, CreateResultReceiver(&sync_status)); 171 sync_engine()->RegisterOrigin(origin, CreateResultReceiver(&sync_status));
171 base::RunLoop().RunUntilIdle(); 172 base::RunLoop().RunUntilIdle();
172 EXPECT_EQ(SYNC_STATUS_OK, sync_status); 173 EXPECT_EQ(SYNC_STATUS_OK, sync_status);
173 ASSERT_TRUE(metadata_database->FindAppRootTracker(kAppID, &tracker)); 174 ASSERT_TRUE(metadata_database->FindAppRootTracker(kAppID, &tracker));
174 EXPECT_EQ(TRACKER_KIND_APP_ROOT, tracker.tracker_kind()); 175 EXPECT_EQ(TRACKER_KIND_APP_ROOT, tracker.tracker_kind());
175 176
176 sync_engine()->DisableOrigin(origin, CreateResultReceiver(&sync_status)); 177 sync_engine()->DisableOrigin(origin, CreateResultReceiver(&sync_status));
177 base::RunLoop().RunUntilIdle(); 178 base::RunLoop().RunUntilIdle();
(...skipping 29 matching lines...) Expand all
207 .Build(); 208 .Build();
208 extension_service()->AddExtension(extension.get()); 209 extension_service()->AddExtension(extension.get());
209 GURL origin = extensions::Extension::GetBaseURLFromExtensionId( 210 GURL origin = extensions::Extension::GetBaseURLFromExtensionId(
210 extension->id()); 211 extension->id());
211 sync_status = SYNC_STATUS_UNKNOWN; 212 sync_status = SYNC_STATUS_UNKNOWN;
212 sync_engine()->RegisterOrigin(origin, CreateResultReceiver(&sync_status)); 213 sync_engine()->RegisterOrigin(origin, CreateResultReceiver(&sync_status));
213 base::RunLoop().RunUntilIdle(); 214 base::RunLoop().RunUntilIdle();
214 EXPECT_EQ(SYNC_STATUS_OK, sync_status); 215 EXPECT_EQ(SYNC_STATUS_OK, sync_status);
215 } 216 }
216 217
217 MetadataDatabase* metadata_database = sync_engine()->GetMetadataDatabase(); 218 MetadataDatabase* metadata_database =
219 sync_engine()->GetMetadataDatabaseForTesting();
218 FileTracker tracker; 220 FileTracker tracker;
219 221
220 ASSERT_TRUE(metadata_database->FindAppRootTracker("app_0", &tracker)); 222 ASSERT_TRUE(metadata_database->FindAppRootTracker("app_0", &tracker));
221 EXPECT_EQ(TRACKER_KIND_APP_ROOT, tracker.tracker_kind()); 223 EXPECT_EQ(TRACKER_KIND_APP_ROOT, tracker.tracker_kind());
222 224
223 ASSERT_TRUE(metadata_database->FindAppRootTracker("app_1", &tracker)); 225 ASSERT_TRUE(metadata_database->FindAppRootTracker("app_1", &tracker));
224 EXPECT_EQ(TRACKER_KIND_APP_ROOT, tracker.tracker_kind()); 226 EXPECT_EQ(TRACKER_KIND_APP_ROOT, tracker.tracker_kind());
225 227
226 ASSERT_TRUE(metadata_database->FindAppRootTracker("app_2", &tracker)); 228 ASSERT_TRUE(metadata_database->FindAppRootTracker("app_2", &tracker));
227 EXPECT_EQ(TRACKER_KIND_APP_ROOT, tracker.tracker_kind()); 229 EXPECT_EQ(TRACKER_KIND_APP_ROOT, tracker.tracker_kind());
(...skipping 147 matching lines...) Expand 10 before | Expand all | Expand 10 after
375 base::Bind(&SyncEngineTest::CheckServiceState, 377 base::Bind(&SyncEngineTest::CheckServiceState,
376 AsWeakPtr(), 378 AsWeakPtr(),
377 SYNC_STATUS_OK, 379 SYNC_STATUS_OK,
378 REMOTE_SERVICE_OK)); 380 REMOTE_SERVICE_OK));
379 381
380 base::RunLoop().RunUntilIdle(); 382 base::RunLoop().RunUntilIdle();
381 } 383 }
382 384
383 } // namespace drive_backend 385 } // namespace drive_backend
384 } // namespace sync_file_system 386 } // namespace sync_file_system
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698