| 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.
|
|
|