Index: chrome/browser/sync/engine/syncer_thread_unittest.cc |
=================================================================== |
--- chrome/browser/sync/engine/syncer_thread_unittest.cc (revision 58702) |
+++ chrome/browser/sync/engine/syncer_thread_unittest.cc (working copy) |
@@ -66,7 +66,7 @@ |
metadb_.name())); |
worker_ = new ModelSafeWorker(); |
SyncSessionContext* context = new SyncSessionContext(connection_.get(), |
- NULL, metadb_.manager(), this); |
+ metadb_.manager(), this); |
syncer_thread_ = new SyncerThread(context); |
syncer_event_hookup_.reset( |
syncer_thread_->relay_channel()->AddObserver(this)); |
@@ -217,12 +217,12 @@ |
}; |
TEST_F(SyncerThreadTest, Construction) { |
- SyncSessionContext* context = new SyncSessionContext(NULL, NULL, NULL, NULL); |
+ SyncSessionContext* context = new SyncSessionContext(NULL, NULL, NULL); |
scoped_refptr<SyncerThread> syncer_thread(new SyncerThread(context)); |
} |
TEST_F(SyncerThreadTest, StartStop) { |
- SyncSessionContext* context = new SyncSessionContext(NULL, NULL, NULL, NULL); |
+ SyncSessionContext* context = new SyncSessionContext(NULL, NULL, NULL); |
scoped_refptr<SyncerThread> syncer_thread(new SyncerThread(context)); |
EXPECT_TRUE(syncer_thread->Start()); |
EXPECT_TRUE(syncer_thread->Stop(2000)); |
@@ -247,7 +247,7 @@ |
} |
TEST_F(SyncerThreadTest, CalculateSyncWaitTime) { |
- SyncSessionContext* context = new SyncSessionContext(NULL, NULL, NULL, NULL); |
+ SyncSessionContext* context = new SyncSessionContext(NULL, NULL, NULL); |
scoped_refptr<SyncerThread> syncer_thread(new SyncerThread(context)); |
syncer_thread->DisableIdleDetection(); |
@@ -307,7 +307,7 @@ |
TEST_F(SyncerThreadTest, CalculatePollingWaitTime) { |
// Set up the environment. |
int user_idle_milliseconds_param = 0; |
- SyncSessionContext* context = new SyncSessionContext(NULL, NULL, NULL, NULL); |
+ SyncSessionContext* context = new SyncSessionContext(NULL, NULL, NULL); |
scoped_refptr<SyncerThread> syncer_thread(new SyncerThread(context)); |
syncer_thread->DisableIdleDetection(); |
// Hold the lock to appease asserts in code. |
@@ -639,8 +639,8 @@ |
syncer_thread()->SetSyncerShortPollInterval(poll_interval); |
EXPECT_TRUE(syncer_thread()->Start()); |
- // Calling Open() should cause the SyncerThread to create a Syncer. |
metadb()->Open(); |
+ syncer_thread()->CreateSyncer(metadb()->name()); |
TimeDelta two_polls = poll_interval + poll_interval; |
// We could theoretically return immediately from the wait if the interceptor |
@@ -673,6 +673,7 @@ |
PreventThreadFromPolling(); |
EXPECT_TRUE(syncer_thread()->Start()); |
metadb()->Open(); |
+ syncer_thread()->CreateSyncer(metadb()->name()); |
const TimeDelta poll_interval = TimeDelta::FromMinutes(5); |
interceptor.WaitForSyncShare(1, poll_interval + poll_interval); |
@@ -697,6 +698,7 @@ |
EXPECT_TRUE(syncer_thread()->Start()); |
metadb()->Open(); |
+ syncer_thread()->CreateSyncer(metadb()->name()); |
// Wait for some healthy syncing. |
interceptor.WaitForSyncShare(4, poll_interval + poll_interval); |
@@ -750,6 +752,7 @@ |
EXPECT_TRUE(syncer_thread()->Start()); |
metadb()->Open(); |
+ syncer_thread()->CreateSyncer(metadb()->name()); |
ASSERT_TRUE(sync_cycle_ended_event.TimedWait(max_wait_time_)); |
connection()->set_store_birthday("NotYourLuckyDay"); |
@@ -765,6 +768,7 @@ |
syncer_thread()->SetSyncerShortPollInterval(poll_interval); |
EXPECT_TRUE(syncer_thread()->Start()); |
metadb()->Open(); |
+ syncer_thread()->CreateSyncer(metadb()->name()); |
// Wait for some healthy syncing. |
interceptor.WaitForSyncShare(2, TimeDelta::FromSeconds(10)); |
@@ -826,6 +830,7 @@ |
Field(&SyncerEvent::what_happened, SyncerEvent::SYNCER_THREAD_EXITING))); |
ASSERT_TRUE(syncer_thread()->Start()); |
metadb()->Open(); |
+ syncer_thread()->CreateSyncer(metadb()->name()); |
ASSERT_TRUE(sync_cycle_ended_event.TimedWait(max_wait_time_)); |
// Request a pause. |
@@ -869,6 +874,7 @@ |
connection()->SetServerNotReachable(); |
metadb()->Open(); |
+ syncer_thread()->CreateSyncer(metadb()->name()); |
// Syncer thread will always go through once cycle at the start, |
// then it will wait for a connection. |
@@ -923,6 +929,8 @@ |
Field(&SyncerEvent::what_happened, SyncerEvent::WAITING_FOR_CONNECTION))). |
WillOnce(SignalEvent(&event)); |
metadb()->Open(); |
+ syncer_thread()->CreateSyncer(metadb()->name()); |
+ |
ASSERT_TRUE(syncer_thread()->Start()); |
ASSERT_TRUE(sync_cycle_ended_event.TimedWait(max_wait_time_)); |
ASSERT_TRUE(event.TimedWait(max_wait_time_)); |
@@ -994,6 +1002,7 @@ |
// Pause the thread then start the syncer. |
ASSERT_TRUE(Pause(&listener)); |
metadb()->Open(); |
+ syncer_thread()->CreateSyncer(metadb()->name()); |
ASSERT_TRUE(syncer_thread()->Start()); |
// Resume and let the syncer cycle. |