| OLD | NEW |
| 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 "sync/engine/sync_session_job.h" | 5 #include "sync/engine/sync_session_job.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
| 9 #include "base/time.h" | 9 #include "base/time.h" |
| 10 #include "sync/internal_api/public/base/model_type_invalidation_map.h" | 10 #include "sync/internal_api/public/base/model_type_invalidation_map.h" |
| (...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 89 const ModelSafeRoutingInfo& routes() { return routes_; } | 89 const ModelSafeRoutingInfo& routes() { return routes_; } |
| 90 | 90 |
| 91 // Checks that the two jobs are "clones" as defined by SyncSessionJob, | 91 // Checks that the two jobs are "clones" as defined by SyncSessionJob, |
| 92 // minus location and SyncSession checking, for reuse in different | 92 // minus location and SyncSession checking, for reuse in different |
| 93 // scenarios. | 93 // scenarios. |
| 94 void ExpectClonesBase(SyncSessionJob* job, SyncSessionJob* clone) { | 94 void ExpectClonesBase(SyncSessionJob* job, SyncSessionJob* clone) { |
| 95 EXPECT_EQ(job->purpose(), clone->purpose()); | 95 EXPECT_EQ(job->purpose(), clone->purpose()); |
| 96 EXPECT_EQ(job->scheduled_start(), clone->scheduled_start()); | 96 EXPECT_EQ(job->scheduled_start(), clone->scheduled_start()); |
| 97 EXPECT_EQ(job->start_step(), clone->start_step()); | 97 EXPECT_EQ(job->start_step(), clone->start_step()); |
| 98 EXPECT_EQ(job->end_step(), clone->end_step()); | 98 EXPECT_EQ(job->end_step(), clone->end_step()); |
| 99 EXPECT_FALSE(clone->is_canary()); | |
| 100 } | 99 } |
| 101 | 100 |
| 102 private: | 101 private: |
| 103 scoped_ptr<sessions::SyncSessionContext> context_; | 102 scoped_ptr<sessions::SyncSessionContext> context_; |
| 104 std::vector<scoped_refptr<ModelSafeWorker> > workers_; | 103 std::vector<scoped_refptr<ModelSafeWorker> > workers_; |
| 105 MockDelegate delegate_; | 104 MockDelegate delegate_; |
| 106 ModelSafeRoutingInfo routes_; | 105 ModelSafeRoutingInfo routes_; |
| 107 bool config_params_callback_invoked_; | 106 bool config_params_callback_invoked_; |
| 108 }; | 107 }; |
| 109 | 108 |
| (...skipping 14 matching lines...) Expand all Loading... |
| 124 | 123 |
| 125 ExpectClonesBase(&job1, clone1.get()); | 124 ExpectClonesBase(&job1, clone1.get()); |
| 126 ExpectClonesBase(&job1, clone1_loc.get()); | 125 ExpectClonesBase(&job1, clone1_loc.get()); |
| 127 EXPECT_NE(job1.session(), clone1->session()); | 126 EXPECT_NE(job1.session(), clone1->session()); |
| 128 EXPECT_EQ(job1.from_location().ToString(), | 127 EXPECT_EQ(job1.from_location().ToString(), |
| 129 clone1->from_location().ToString()); | 128 clone1->from_location().ToString()); |
| 130 EXPECT_NE(job1.session(), clone1_loc->session()); | 129 EXPECT_NE(job1.session(), clone1_loc->session()); |
| 131 EXPECT_EQ(from_here1.ToString(), clone1_loc->from_location().ToString()); | 130 EXPECT_EQ(from_here1.ToString(), clone1_loc->from_location().ToString()); |
| 132 | 131 |
| 133 context()->set_routing_info(routes()); | 132 context()->set_routing_info(routes()); |
| 134 clone1->GrantCanaryPrivilege(); | |
| 135 sessions::test_util::SimulateSuccess(clone1->mutable_session(), | 133 sessions::test_util::SimulateSuccess(clone1->mutable_session(), |
| 136 clone1->start_step(), | 134 clone1->start_step(), |
| 137 clone1->end_step()); | 135 clone1->end_step()); |
| 138 clone1->Finish(false); | 136 clone1->Finish(false); |
| 139 const tracked_objects::Location from_here2(FROM_HERE); | 137 const tracked_objects::Location from_here2(FROM_HERE); |
| 140 scoped_ptr<SyncSessionJob> clone2 = clone1->Clone(); | 138 scoped_ptr<SyncSessionJob> clone2 = clone1->Clone(); |
| 141 scoped_ptr<SyncSessionJob> clone2_loc(clone1->CloneFromLocation(from_here2)); | 139 scoped_ptr<SyncSessionJob> clone2_loc(clone1->CloneFromLocation(from_here2)); |
| 142 | 140 |
| 143 ExpectClonesBase(clone1.get(), clone2.get()); | 141 ExpectClonesBase(clone1.get(), clone2.get()); |
| 144 ExpectClonesBase(clone1.get(), clone2_loc.get()); | 142 ExpectClonesBase(clone1.get(), clone2_loc.get()); |
| (...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 217 SyncSessionJob job1(SyncSessionJob::CONFIGURATION, TimeTicks::Now(), | 215 SyncSessionJob job1(SyncSessionJob::CONFIGURATION, TimeTicks::Now(), |
| 218 session.Pass(), params, FROM_HERE); | 216 session.Pass(), params, FROM_HERE); |
| 219 sessions::test_util::SimulateSuccess(job1.mutable_session(), | 217 sessions::test_util::SimulateSuccess(job1.mutable_session(), |
| 220 job1.start_step(), | 218 job1.start_step(), |
| 221 job1.end_step()); | 219 job1.end_step()); |
| 222 job1.Finish(false); | 220 job1.Finish(false); |
| 223 EXPECT_TRUE(config_params_callback_invoked()); | 221 EXPECT_TRUE(config_params_callback_invoked()); |
| 224 } | 222 } |
| 225 | 223 |
| 226 } // namespace syncer | 224 } // namespace syncer |
| OLD | NEW |