OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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/synchronization/waitable_event.h" | 5 #include "base/synchronization/waitable_event.h" |
6 #include "base/test/test_timeouts.h" | 6 #include "base/test/test_timeouts.h" |
7 #include "chrome/browser/sync/engine/mock_model_safe_workers.h" | 7 #include "chrome/browser/sync/engine/mock_model_safe_workers.h" |
8 #include "chrome/browser/sync/engine/syncer.h" | 8 #include "chrome/browser/sync/engine/syncer.h" |
9 #include "chrome/browser/sync/engine/syncer_thread2.h" | 9 #include "chrome/browser/sync/engine/syncer_thread2.h" |
10 #include "chrome/browser/sync/sessions/test_util.h" | 10 #include "chrome/browser/sync/sessions/test_util.h" |
(...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
81 } | 81 } |
82 | 82 |
83 void AnalyzePollRun(const SyncShareRecords& records, size_t min_num_samples, | 83 void AnalyzePollRun(const SyncShareRecords& records, size_t min_num_samples, |
84 const TimeTicks& optimal_start, const TimeDelta& poll_interval) { | 84 const TimeTicks& optimal_start, const TimeDelta& poll_interval) { |
85 const std::vector<TimeTicks>& data(records.times); | 85 const std::vector<TimeTicks>& data(records.times); |
86 EXPECT_GE(data.size(), min_num_samples); | 86 EXPECT_GE(data.size(), min_num_samples); |
87 for (size_t i = 0; i < data.size(); i++) { | 87 for (size_t i = 0; i < data.size(); i++) { |
88 SCOPED_TRACE(testing::Message() << "SyncShare # (" << i << ")"); | 88 SCOPED_TRACE(testing::Message() << "SyncShare # (" << i << ")"); |
89 TimeTicks optimal_next_sync = optimal_start + poll_interval * i; | 89 TimeTicks optimal_next_sync = optimal_start + poll_interval * i; |
90 EXPECT_GE(data[i], optimal_next_sync); | 90 EXPECT_GE(data[i], optimal_next_sync); |
91 EXPECT_LT(data[i], optimal_next_sync + poll_interval); | 91 EXPECT_LE(data[i], optimal_next_sync + poll_interval); |
92 EXPECT_EQ(GetUpdatesCallerInfo::PERIODIC, | 92 EXPECT_EQ(GetUpdatesCallerInfo::PERIODIC, |
93 records.snapshots[i]->source.first); | 93 records.snapshots[i]->source.first); |
94 } | 94 } |
95 } | 95 } |
96 | 96 |
97 bool GetBackoffAndResetTest(base::WaitableEvent* done) { | 97 bool GetBackoffAndResetTest(base::WaitableEvent* done) { |
98 syncable::ModelTypeBitSet nudge_types; | 98 syncable::ModelTypeBitSet nudge_types; |
99 syncer_thread()->Start(SyncerThread::NORMAL_MODE); | 99 syncer_thread()->Start(SyncerThread::NORMAL_MODE); |
100 syncer_thread()->ScheduleNudge(zero(), NUDGE_SOURCE_LOCAL, nudge_types); | 100 syncer_thread()->ScheduleNudge(zero(), NUDGE_SOURCE_LOCAL, nudge_types); |
101 done->TimedWait(timeout()); | 101 done->TimedWait(timeout()); |
(...skipping 393 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
495 .WillOnce(Invoke(sessions::test_util::SimulateCommitFailed)) | 495 .WillOnce(Invoke(sessions::test_util::SimulateCommitFailed)) |
496 .WillOnce(Invoke(sessions::test_util::SimulateCommitFailed)) | 496 .WillOnce(Invoke(sessions::test_util::SimulateCommitFailed)) |
497 .WillRepeatedly(DoAll(Invoke(sessions::test_util::SimulateSuccess), | 497 .WillRepeatedly(DoAll(Invoke(sessions::test_util::SimulateSuccess), |
498 RecordSyncShareAndPostSignal(&r, kMinNumSamples, this, &done))); | 498 RecordSyncShareAndPostSignal(&r, kMinNumSamples, this, &done))); |
499 EXPECT_CALL(*delay(), GetDelay(_)).WillOnce(Return(backoff)); | 499 EXPECT_CALL(*delay(), GetDelay(_)).WillOnce(Return(backoff)); |
500 | 500 |
501 // Optimal start for the post-backoff poll party. | 501 // Optimal start for the post-backoff poll party. |
502 TimeTicks optimal_start = TimeTicks::Now() + poll + backoff; | 502 TimeTicks optimal_start = TimeTicks::Now() + poll + backoff; |
503 syncer_thread()->Start(SyncerThread::NORMAL_MODE); | 503 syncer_thread()->Start(SyncerThread::NORMAL_MODE); |
504 done.TimedWait(timeout()); | 504 done.TimedWait(timeout()); |
| 505 syncer_thread()->Stop(); |
505 | 506 |
506 // Check for healthy polling after backoff is relieved. | 507 // Check for healthy polling after backoff is relieved. |
507 // Can't use AnalyzePollRun because first sync is a continuation. Bleh. | 508 // Can't use AnalyzePollRun because first sync is a continuation. Bleh. |
508 for (size_t i = 0; i < r.times.size(); i++) { | 509 for (size_t i = 0; i < r.times.size(); i++) { |
509 SCOPED_TRACE(testing::Message() << "SyncShare # (" << i << ")"); | 510 SCOPED_TRACE(testing::Message() << "SyncShare # (" << i << ")"); |
510 TimeTicks optimal_next_sync = optimal_start + poll * i; | 511 TimeTicks optimal_next_sync = optimal_start + poll * i; |
511 EXPECT_GE(r.times[i], optimal_next_sync); | 512 EXPECT_GE(r.times[i], optimal_next_sync); |
512 EXPECT_LT(r.times[i], optimal_next_sync + poll); | 513 EXPECT_LE(r.times[i], optimal_next_sync + poll); |
513 EXPECT_EQ(i == 0 ? GetUpdatesCallerInfo::SYNC_CYCLE_CONTINUATION | 514 EXPECT_EQ(i == 0 ? GetUpdatesCallerInfo::SYNC_CYCLE_CONTINUATION |
514 : GetUpdatesCallerInfo::PERIODIC, | 515 : GetUpdatesCallerInfo::PERIODIC, |
515 r.snapshots[i]->source.first); | 516 r.snapshots[i]->source.first); |
516 } | 517 } |
517 } | 518 } |
518 | 519 |
519 TEST_F(SyncerThread2Test, GetRecommendedDelay) { | 520 TEST_F(SyncerThread2Test, GetRecommendedDelay) { |
520 EXPECT_LE(TimeDelta::FromSeconds(0), | 521 EXPECT_LE(TimeDelta::FromSeconds(0), |
521 SyncerThread::GetRecommendedDelay(TimeDelta::FromSeconds(0))); | 522 SyncerThread::GetRecommendedDelay(TimeDelta::FromSeconds(0))); |
522 EXPECT_LE(TimeDelta::FromSeconds(1), | 523 EXPECT_LE(TimeDelta::FromSeconds(1), |
(...skipping 22 matching lines...) Expand all Loading... |
545 TEST_F(SyncerThread2Test, DISABLED_StartWhenNotConnected) { | 546 TEST_F(SyncerThread2Test, DISABLED_StartWhenNotConnected) { |
546 | 547 |
547 } | 548 } |
548 | 549 |
549 } // namespace s3 | 550 } // namespace s3 |
550 } // namespace browser_sync | 551 } // namespace browser_sync |
551 | 552 |
552 // SyncerThread won't outlive the test! | 553 // SyncerThread won't outlive the test! |
553 DISABLE_RUNNABLE_METHOD_REFCOUNT(browser_sync::s3::SyncerThread2Test); | 554 DISABLE_RUNNABLE_METHOD_REFCOUNT(browser_sync::s3::SyncerThread2Test); |
554 | 555 |
OLD | NEW |