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

Side by Side Diff: chrome/browser/sync/engine/sync_scheduler_whitebox_unittest.cc

Issue 9348036: Trim code from sync's ServerConnectionManager (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: small updates Created 8 years, 10 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) 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/message_loop.h" 5 #include "base/message_loop.h"
6 #include "base/time.h" 6 #include "base/time.h"
7 #include "chrome/browser/sync/engine/sync_scheduler.h" 7 #include "chrome/browser/sync/engine/sync_scheduler.h"
8 #include "chrome/browser/sync/sessions/sync_session_context.h" 8 #include "chrome/browser/sync/sessions/sync_session_context.h"
9 #include "chrome/browser/sync/sessions/test_util.h" 9 #include "chrome/browser/sync/sessions/test_util.h"
10 #include "chrome/browser/sync/test/engine/fake_model_safe_worker_registrar.h" 10 #include "chrome/browser/sync/test/engine/fake_model_safe_worker_registrar.h"
(...skipping 12 matching lines...) Expand all
23 class SyncSchedulerWhiteboxTest : public testing::Test { 23 class SyncSchedulerWhiteboxTest : public testing::Test {
24 public: 24 public:
25 virtual void SetUp() { 25 virtual void SetUp() {
26 syncdb_.SetUp(); 26 syncdb_.SetUp();
27 Syncer* syncer = new Syncer(); 27 Syncer* syncer = new Syncer();
28 ModelSafeRoutingInfo routes; 28 ModelSafeRoutingInfo routes;
29 routes[syncable::BOOKMARKS] = GROUP_UI; 29 routes[syncable::BOOKMARKS] = GROUP_UI;
30 routes[syncable::NIGORI] = GROUP_PASSIVE; 30 routes[syncable::NIGORI] = GROUP_PASSIVE;
31 registrar_.reset(new FakeModelSafeWorkerRegistrar(routes)); 31 registrar_.reset(new FakeModelSafeWorkerRegistrar(routes));
32 connection_.reset(new MockConnectionManager(syncdb_.manager(), "Test")); 32 connection_.reset(new MockConnectionManager(syncdb_.manager(), "Test"));
33 connection_->SetServerReachable();
34 context_ = new SyncSessionContext(connection_.get(), syncdb_.manager(), 33 context_ = new SyncSessionContext(connection_.get(), syncdb_.manager(),
35 registrar_.get(), std::vector<SyncEngineEventListener*>(), NULL); 34 registrar_.get(), std::vector<SyncEngineEventListener*>(), NULL);
36 context_->set_notifications_enabled(true); 35 context_->set_notifications_enabled(true);
37 context_->set_account_name("Test"); 36 context_->set_account_name("Test");
38 scheduler_.reset( 37 scheduler_.reset(
39 new SyncScheduler("TestSyncSchedulerWhitebox", context_, syncer)); 38 new SyncScheduler("TestSyncSchedulerWhitebox", context_, syncer));
40 } 39 }
41 40
42 virtual void TearDown() { 41 virtual void TearDown() {
43 scheduler_.reset(); 42 scheduler_.reset();
44 syncdb_.TearDown(); 43 syncdb_.TearDown();
45 } 44 }
46 45
47 void SetMode(SyncScheduler::Mode mode) { 46 void SetMode(SyncScheduler::Mode mode) {
48 scheduler_->mode_ = mode; 47 scheduler_->mode_ = mode;
49 } 48 }
50 49
51 void SetLastSyncedTime(base::TimeTicks ticks) { 50 void SetLastSyncedTime(base::TimeTicks ticks) {
52 scheduler_->last_sync_session_end_time_ = ticks; 51 scheduler_->last_sync_session_end_time_ = ticks;
53 } 52 }
54 53
55 void SetServerConnection(bool connected) {
56 scheduler_->server_connection_ok_ = connected;
57 }
58
59 void ResetWaitInterval() { 54 void ResetWaitInterval() {
60 scheduler_->wait_interval_.reset(); 55 scheduler_->wait_interval_.reset();
61 } 56 }
62 57
63 void SetWaitIntervalToThrottled() { 58 void SetWaitIntervalToThrottled() {
64 scheduler_->wait_interval_.reset(new SyncScheduler::WaitInterval( 59 scheduler_->wait_interval_.reset(new SyncScheduler::WaitInterval(
65 SyncScheduler::WaitInterval::THROTTLED, TimeDelta::FromSeconds(1))); 60 SyncScheduler::WaitInterval::THROTTLED, TimeDelta::FromSeconds(1)));
66 } 61 }
67 62
68 void SetWaitIntervalToExponentialBackoff() { 63 void SetWaitIntervalToExponentialBackoff() {
69 scheduler_->wait_interval_.reset( 64 scheduler_->wait_interval_.reset(
70 new SyncScheduler::WaitInterval( 65 new SyncScheduler::WaitInterval(
71 SyncScheduler::WaitInterval::EXPONENTIAL_BACKOFF, 66 SyncScheduler::WaitInterval::EXPONENTIAL_BACKOFF,
72 TimeDelta::FromSeconds(1))); 67 TimeDelta::FromSeconds(1)));
73 } 68 }
74 69
75 void SetWaitIntervalHadNudge(bool had_nudge) { 70 void SetWaitIntervalHadNudge(bool had_nudge) {
76 scheduler_->wait_interval_->had_nudge = had_nudge; 71 scheduler_->wait_interval_->had_nudge = had_nudge;
77 } 72 }
78 73
79 SyncScheduler::JobProcessDecision DecideOnJob( 74 SyncScheduler::JobProcessDecision DecideOnJob(
80 const SyncScheduler::SyncSessionJob& job) { 75 const SyncScheduler::SyncSessionJob& job) {
81 return scheduler_->DecideOnJob(job); 76 return scheduler_->DecideOnJob(job);
82 } 77 }
83 78
84 void InitializeSyncerOnNormalMode() { 79 void InitializeSyncerOnNormalMode() {
85 SetMode(SyncScheduler::NORMAL_MODE); 80 SetMode(SyncScheduler::NORMAL_MODE);
86 ResetWaitInterval(); 81 ResetWaitInterval();
87 SetServerConnection(true);
88 SetLastSyncedTime(base::TimeTicks::Now()); 82 SetLastSyncedTime(base::TimeTicks::Now());
89 } 83 }
90 84
91 SyncScheduler::JobProcessDecision CreateAndDecideJob( 85 SyncScheduler::JobProcessDecision CreateAndDecideJob(
92 SyncScheduler::SyncSessionJob::SyncSessionJobPurpose purpose) { 86 SyncScheduler::SyncSessionJob::SyncSessionJobPurpose purpose) {
93 struct SyncScheduler::SyncSessionJob job; 87 struct SyncScheduler::SyncSessionJob job;
94 job.purpose = purpose; 88 job.purpose = purpose;
95 job.scheduled_start = TimeTicks::Now(); 89 job.scheduled_start = TimeTicks::Now();
96 return DecideOnJob(job); 90 return DecideOnJob(job);
97 } 91 }
(...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after
227 struct SyncScheduler::SyncSessionJob job; 221 struct SyncScheduler::SyncSessionJob job;
228 job.purpose = SyncScheduler::SyncSessionJob::CONFIGURATION; 222 job.purpose = SyncScheduler::SyncSessionJob::CONFIGURATION;
229 job.scheduled_start = TimeTicks::Now(); 223 job.scheduled_start = TimeTicks::Now();
230 job.is_canary_job = true; 224 job.is_canary_job = true;
231 SyncScheduler::JobProcessDecision decision = DecideOnJob(job); 225 SyncScheduler::JobProcessDecision decision = DecideOnJob(job);
232 226
233 EXPECT_EQ(decision, SyncScheduler::CONTINUE); 227 EXPECT_EQ(decision, SyncScheduler::CONTINUE);
234 } 228 }
235 229
236 } // namespace browser_sync 230 } // namespace browser_sync
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698