OLD | NEW |
1 // Copyright (c) 2009 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2009 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 // Mock ServerConnectionManager class for use in client regression tests. | 5 // Mock ServerConnectionManager class for use in client regression tests. |
6 | 6 |
7 #include "chrome/test/sync/engine/mock_connection_manager.h" | 7 #include "chrome/test/sync/engine/mock_connection_manager.h" |
8 | 8 |
9 #include "chrome/browser/sync/engine/syncer_proto_util.h" | 9 #include "chrome/browser/sync/engine/syncer_proto_util.h" |
10 #include "chrome/browser/sync/protocol/bookmark_specifics.pb.h" | 10 #include "chrome/browser/sync/protocol/bookmark_specifics.pb.h" |
(...skipping 120 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
131 ProcessClearData(&post, &response); | 131 ProcessClearData(&post, &response); |
132 } else { | 132 } else { |
133 EXPECT_TRUE(false) << "Unknown/unsupported ClientToServerMessage"; | 133 EXPECT_TRUE(false) << "Unknown/unsupported ClientToServerMessage"; |
134 return false; | 134 return false; |
135 } | 135 } |
136 if (client_command_.get()) { | 136 if (client_command_.get()) { |
137 response.mutable_client_command()->CopyFrom(*client_command_.get()); | 137 response.mutable_client_command()->CopyFrom(*client_command_.get()); |
138 } | 138 } |
139 | 139 |
140 { | 140 { |
141 AutoLock lock(response_code_override_lock_); | 141 base::AutoLock lock(response_code_override_lock_); |
142 if (throttling_) { | 142 if (throttling_) { |
143 response.set_error_code(ClientToServerResponse::THROTTLED); | 143 response.set_error_code(ClientToServerResponse::THROTTLED); |
144 throttling_ = false; | 144 throttling_ = false; |
145 } | 145 } |
146 | 146 |
147 if (fail_with_auth_invalid_) | 147 if (fail_with_auth_invalid_) |
148 response.set_error_code(ClientToServerResponse::AUTH_INVALID); | 148 response.set_error_code(ClientToServerResponse::AUTH_INVALID); |
149 } | 149 } |
150 | 150 |
151 response.SerializeToString(params->buffer_out); | 151 response.SerializeToString(params->buffer_out); |
(...skipping 342 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
494 return *commit_messages_->back(); | 494 return *commit_messages_->back(); |
495 } | 495 } |
496 | 496 |
497 const CommitResponse& MockConnectionManager::last_commit_response() const { | 497 const CommitResponse& MockConnectionManager::last_commit_response() const { |
498 EXPECT_TRUE(!commit_responses_.empty()); | 498 EXPECT_TRUE(!commit_responses_.empty()); |
499 return *commit_responses_->back(); | 499 return *commit_responses_->back(); |
500 } | 500 } |
501 | 501 |
502 void MockConnectionManager::ThrottleNextRequest( | 502 void MockConnectionManager::ThrottleNextRequest( |
503 ResponseCodeOverrideRequestor* visitor) { | 503 ResponseCodeOverrideRequestor* visitor) { |
504 AutoLock lock(response_code_override_lock_); | 504 base::AutoLock lock(response_code_override_lock_); |
505 throttling_ = true; | 505 throttling_ = true; |
506 if (visitor) | 506 if (visitor) |
507 visitor->OnOverrideComplete(); | 507 visitor->OnOverrideComplete(); |
508 } | 508 } |
509 | 509 |
510 void MockConnectionManager::FailWithAuthInvalid( | 510 void MockConnectionManager::FailWithAuthInvalid( |
511 ResponseCodeOverrideRequestor* visitor) { | 511 ResponseCodeOverrideRequestor* visitor) { |
512 AutoLock lock(response_code_override_lock_); | 512 base::AutoLock lock(response_code_override_lock_); |
513 fail_with_auth_invalid_ = true; | 513 fail_with_auth_invalid_ = true; |
514 if (visitor) | 514 if (visitor) |
515 visitor->OnOverrideComplete(); | 515 visitor->OnOverrideComplete(); |
516 } | 516 } |
517 | 517 |
518 void MockConnectionManager::StopFailingWithAuthInvalid( | 518 void MockConnectionManager::StopFailingWithAuthInvalid( |
519 ResponseCodeOverrideRequestor* visitor) { | 519 ResponseCodeOverrideRequestor* visitor) { |
520 AutoLock lock(response_code_override_lock_); | 520 base::AutoLock lock(response_code_override_lock_); |
521 fail_with_auth_invalid_ = false; | 521 fail_with_auth_invalid_ = false; |
522 if (visitor) | 522 if (visitor) |
523 visitor->OnOverrideComplete(); | 523 visitor->OnOverrideComplete(); |
524 } | 524 } |
525 | 525 |
526 bool MockConnectionManager::IsModelTypePresentInSpecifics( | 526 bool MockConnectionManager::IsModelTypePresentInSpecifics( |
527 const sync_pb::EntitySpecifics& filter, syncable::ModelType value) { | 527 const sync_pb::EntitySpecifics& filter, syncable::ModelType value) { |
528 // This implementation is a little contorted; it's done this way | 528 // This implementation is a little contorted; it's done this way |
529 // to avoid having to switch on the ModelType. We're basically doing | 529 // to avoid having to switch on the ModelType. We're basically doing |
530 // the protobuf equivalent of ((value & filter) == filter). | 530 // the protobuf equivalent of ((value & filter) == filter). |
(...skipping 15 matching lines...) Expand all Loading... |
546 | 546 |
547 void MockConnectionManager::SetServerNotReachable() { | 547 void MockConnectionManager::SetServerNotReachable() { |
548 server_status_ = HttpResponse::CONNECTION_UNAVAILABLE; | 548 server_status_ = HttpResponse::CONNECTION_UNAVAILABLE; |
549 server_reachable_ = false; | 549 server_reachable_ = false; |
550 browser_sync::ServerConnectionEvent event = { | 550 browser_sync::ServerConnectionEvent event = { |
551 browser_sync::ServerConnectionEvent::STATUS_CHANGED, | 551 browser_sync::ServerConnectionEvent::STATUS_CHANGED, |
552 server_status_, | 552 server_status_, |
553 server_reachable_ }; | 553 server_reachable_ }; |
554 channel_->NotifyListeners(event); | 554 channel_->NotifyListeners(event); |
555 } | 555 } |
OLD | NEW |