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

Side by Side Diff: sync/engine/sync_scheduler_unittest.cc

Issue 10455012: [Sync] Add support for performing a GetKey on startup. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Rebase Created 8 years, 5 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 (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 "base/bind.h" 5 #include "base/bind.h"
6 #include "base/callback.h" 6 #include "base/callback.h"
7 #include "base/compiler_specific.h" 7 #include "base/compiler_specific.h"
8 #include "base/memory/weak_ptr.h" 8 #include "base/memory/weak_ptr.h"
9 #include "base/message_loop.h" 9 #include "base/message_loop.h"
10 #include "base/test/test_timeouts.h" 10 #include "base/test/test_timeouts.h"
(...skipping 102 matching lines...) Expand 10 before | Expand all | Expand 10 after
113 workers_.begin(); it != workers_.end(); ++it) { 113 workers_.begin(); it != workers_.end(); ++it) {
114 workers.push_back(it->get()); 114 workers.push_back(it->get());
115 } 115 }
116 116
117 connection_.reset(new MockConnectionManager(directory())); 117 connection_.reset(new MockConnectionManager(directory()));
118 connection_->SetServerReachable(); 118 connection_->SetServerReachable();
119 throttled_data_type_tracker_.reset(new ThrottledDataTypeTracker(NULL)); 119 throttled_data_type_tracker_.reset(new ThrottledDataTypeTracker(NULL));
120 context_.reset(new SyncSessionContext( 120 context_.reset(new SyncSessionContext(
121 connection_.get(), directory(), routing_info, workers, 121 connection_.get(), directory(), routing_info, workers,
122 &extensions_activity_monitor_, throttled_data_type_tracker_.get(), 122 &extensions_activity_monitor_, throttled_data_type_tracker_.get(),
123 std::vector<SyncEngineEventListener*>(), NULL, NULL)); 123 std::vector<SyncEngineEventListener*>(), NULL, NULL,
124 true /* enable keystore encryption */));
124 context_->set_notifications_enabled(true); 125 context_->set_notifications_enabled(true);
125 context_->set_account_name("Test"); 126 context_->set_account_name("Test");
126 scheduler_.reset( 127 scheduler_.reset(
127 new SyncScheduler("TestSyncScheduler", context(), syncer_)); 128 new SyncScheduler("TestSyncScheduler", context(), syncer_));
128 } 129 }
129 130
130 SyncScheduler* scheduler() { return scheduler_.get(); } 131 SyncScheduler* scheduler() { return scheduler_.get(); }
131 MockSyncer* syncer() { return syncer_; } 132 MockSyncer* syncer() { return syncer_; }
132 MockDelayProvider* delay() { return delay_; } 133 MockDelayProvider* delay() { return delay_; }
133 MockConnectionManager* connection() { return connection_.get(); } 134 MockConnectionManager* connection() { return connection_.get(); }
(...skipping 925 matching lines...) Expand 10 before | Expand all | Expand 10 after
1059 scheduler()->ScheduleNudgeAsync( 1060 scheduler()->ScheduleNudgeAsync(
1060 zero(), NUDGE_SOURCE_LOCAL, ModelTypeSet(), FROM_HERE); 1061 zero(), NUDGE_SOURCE_LOCAL, ModelTypeSet(), FROM_HERE);
1061 PumpLoop(); 1062 PumpLoop();
1062 // Pump again to run job. 1063 // Pump again to run job.
1063 PumpLoop(); 1064 PumpLoop();
1064 1065
1065 StopSyncScheduler(); 1066 StopSyncScheduler();
1066 Mock::VerifyAndClearExpectations(syncer()); 1067 Mock::VerifyAndClearExpectations(syncer());
1067 1068
1068 // Configuration. 1069 // Configuration.
1069 EXPECT_CALL(*syncer(), SyncShare(_, DOWNLOAD_UPDATES, APPLY_UPDATES)) 1070 EXPECT_CALL(*syncer(), SyncShare(_, GET_ENCRYPTION_KEY, APPLY_UPDATES))
1070 .WillOnce(Invoke(sessions::test_util::SimulateSuccess)); 1071 .WillOnce(Invoke(sessions::test_util::SimulateSuccess));
1071 StartSyncScheduler(SyncScheduler::CONFIGURATION_MODE); 1072 StartSyncScheduler(SyncScheduler::CONFIGURATION_MODE);
1072 1073
1073 syncer::ModelTypeSet model_types(syncer::BOOKMARKS); 1074 syncer::ModelTypeSet model_types(syncer::BOOKMARKS);
1074 CallbackCounter counter; 1075 CallbackCounter counter;
1075 ConfigurationParams params( 1076 ConfigurationParams params(
1076 GetUpdatesCallerInfo::RECONFIGURATION, 1077 GetUpdatesCallerInfo::RECONFIGURATION,
1077 model_types, 1078 model_types,
1078 TypesToRoutingInfo(model_types), 1079 TypesToRoutingInfo(model_types),
1079 ConfigurationParams::KEYSTORE_KEY_UNNECESSARY, 1080 ConfigurationParams::KEYSTORE_KEY_NEEDED,
1080 base::Bind(&CallbackCounter::Callback, base::Unretained(&counter))); 1081 base::Bind(&CallbackCounter::Callback, base::Unretained(&counter)));
1081 ASSERT_TRUE(scheduler()->ScheduleConfiguration(params)); 1082 ASSERT_TRUE(scheduler()->ScheduleConfiguration(params));
1082 ASSERT_EQ(1, counter.times_called()); 1083 ASSERT_EQ(1, counter.times_called());
1083 // Runs directly so no need to pump the loop. 1084 // Runs directly so no need to pump the loop.
1084 StopSyncScheduler(); 1085 StopSyncScheduler();
1085 Mock::VerifyAndClearExpectations(syncer()); 1086 Mock::VerifyAndClearExpectations(syncer());
1086 1087
1087 StartSyncScheduler(SyncScheduler::NORMAL_MODE); 1088 StartSyncScheduler(SyncScheduler::NORMAL_MODE);
1088 1089
1089 // Poll. 1090 // Poll.
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after
1123 // Should save the nudge for until after the server is reachable. 1124 // Should save the nudge for until after the server is reachable.
1124 MessageLoop::current()->RunAllPending(); 1125 MessageLoop::current()->RunAllPending();
1125 1126
1126 connection()->SetServerReachable(); 1127 connection()->SetServerReachable();
1127 connection()->UpdateConnectionStatus(); 1128 connection()->UpdateConnectionStatus();
1128 scheduler()->OnConnectionStatusChange(); 1129 scheduler()->OnConnectionStatusChange();
1129 MessageLoop::current()->RunAllPending(); 1130 MessageLoop::current()->RunAllPending();
1130 } 1131 }
1131 1132
1132 } // namespace browser_sync 1133 } // namespace browser_sync
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698