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

Side by Side Diff: sync/test/fake_server/fake_server.cc

Issue 642613002: Use Sync FakeServer in exponential backoff tests (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 6 years, 2 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
« no previous file with comments | « sync/test/fake_server/fake_server.h ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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/test/fake_server/fake_server.h" 5 #include "sync/test/fake_server/fake_server.h"
6 6
7 #include <algorithm> 7 #include <algorithm>
8 #include <limits> 8 #include <limits>
9 #include <string> 9 #include <string>
10 #include <vector> 10 #include <vector>
(...skipping 131 matching lines...) Expand 10 before | Expand all | Expand 10 after
142 142
143 return scoped_ptr<UpdateSieve>( 143 return scoped_ptr<UpdateSieve>(
144 new UpdateSieve(request_from_version, min_version)); 144 new UpdateSieve(request_from_version, min_version));
145 } 145 }
146 146
147 } // namespace 147 } // namespace
148 148
149 FakeServer::FakeServer() : version_(0), 149 FakeServer::FakeServer() : version_(0),
150 store_birthday_(kDefaultStoreBirthday), 150 store_birthday_(kDefaultStoreBirthday),
151 authenticated_(true), 151 authenticated_(true),
152 error_type_(sync_pb::SyncEnums::SUCCESS) { 152 error_type_(sync_pb::SyncEnums::SUCCESS),
153 network_enabled_(true) {
153 keystore_keys_.push_back(kDefaultKeystoreKey); 154 keystore_keys_.push_back(kDefaultKeystoreKey);
154 CHECK(CreateDefaultPermanentItems()); 155 CHECK(CreateDefaultPermanentItems());
155 } 156 }
156 157
157 FakeServer::~FakeServer() { 158 FakeServer::~FakeServer() {
158 STLDeleteContainerPairSecondPointers(entities_.begin(), entities_.end()); 159 STLDeleteContainerPairSecondPointers(entities_.begin(), entities_.end());
159 } 160 }
160 161
161 bool FakeServer::CreateDefaultPermanentItems() { 162 bool FakeServer::CreateDefaultPermanentItems() {
162 ModelTypeSet all_types = syncer::ProtocolTypes(); 163 ModelTypeSet all_types = syncer::ProtocolTypes();
(...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after
211 } 212 }
212 213
213 void FakeServer::SaveEntity(FakeServerEntity* entity) { 214 void FakeServer::SaveEntity(FakeServerEntity* entity) {
214 delete entities_[entity->GetId()]; 215 delete entities_[entity->GetId()];
215 entity->SetVersion(++version_); 216 entity->SetVersion(++version_);
216 entities_[entity->GetId()] = entity; 217 entities_[entity->GetId()] = entity;
217 } 218 }
218 219
219 void FakeServer::HandleCommand(const string& request, 220 void FakeServer::HandleCommand(const string& request,
220 const HandleCommandCallback& callback) { 221 const HandleCommandCallback& callback) {
222 if (!network_enabled_) {
223 callback.Run(net::ERR_FAILED, net::ERR_FAILED, string());
224 return;
225 }
226
221 if (!authenticated_) { 227 if (!authenticated_) {
222 callback.Run(0, net::HTTP_UNAUTHORIZED, string()); 228 callback.Run(0, net::HTTP_UNAUTHORIZED, string());
223 return; 229 return;
224 } 230 }
225 231
226 sync_pb::ClientToServerMessage message; 232 sync_pb::ClientToServerMessage message;
227 bool parsed = message.ParseFromString(request); 233 bool parsed = message.ParseFromString(request);
228 CHECK(parsed) << "Unable to parse the ClientToServerMessage."; 234 CHECK(parsed) << "Unable to parse the ClientToServerMessage.";
229 235
230 sync_pb::ClientToServerResponse response_proto; 236 sync_pb::ClientToServerResponse response_proto;
(...skipping 301 matching lines...) Expand 10 before | Expand all | Expand 10 after
532 } 538 }
533 539
534 void FakeServer::AddObserver(Observer* observer) { 540 void FakeServer::AddObserver(Observer* observer) {
535 observers_.AddObserver(observer); 541 observers_.AddObserver(observer);
536 } 542 }
537 543
538 void FakeServer::RemoveObserver(Observer* observer) { 544 void FakeServer::RemoveObserver(Observer* observer) {
539 observers_.RemoveObserver(observer); 545 observers_.RemoveObserver(observer);
540 } 546 }
541 547
548 void FakeServer::EnableNetwork() {
549 network_enabled_ = true;
550 }
551
552 void FakeServer::DisableNetwork() {
553 network_enabled_ = false;
554 }
555
542 } // namespace fake_server 556 } // namespace fake_server
OLDNEW
« no previous file with comments | « sync/test/fake_server/fake_server.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698