| 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/sessions/test_util.h" | 5 #include "sync/sessions/test_util.h" |
| 6 | 6 |
| 7 namespace syncer { | 7 namespace syncer { |
| 8 namespace sessions { | 8 namespace sessions { |
| 9 namespace test_util { | 9 namespace test_util { |
| 10 | 10 |
| 11 void SimulateHasMoreToSync(sessions::SyncSession* session, | |
| 12 SyncerStep begin, SyncerStep end) { | |
| 13 session->mutable_status_controller()->update_conflicts_resolved(true); | |
| 14 ASSERT_TRUE(session->HasMoreToSync()); | |
| 15 } | |
| 16 | |
| 17 void SimulateGetEncryptionKeyFailed(sessions::SyncSession* session, | 11 void SimulateGetEncryptionKeyFailed(sessions::SyncSession* session, |
| 18 SyncerStep begin, SyncerStep end) { | 12 SyncerStep begin, SyncerStep end) { |
| 19 session->mutable_status_controller()->set_last_get_key_result( | 13 session->mutable_status_controller()->set_last_get_key_result( |
| 20 SERVER_RESPONSE_VALIDATION_FAILED); | 14 SERVER_RESPONSE_VALIDATION_FAILED); |
| 21 session->mutable_status_controller()->set_last_download_updates_result( | 15 session->mutable_status_controller()->set_last_download_updates_result( |
| 22 SYNCER_OK); | 16 SYNCER_OK); |
| 23 } | 17 } |
| 24 | 18 |
| 25 void SimulateDownloadUpdatesFailed(sessions::SyncSession* session, | 19 void SimulateDownloadUpdatesFailed(sessions::SyncSession* session, |
| 26 SyncerStep begin, SyncerStep end) { | 20 SyncerStep begin, SyncerStep end) { |
| 27 session->mutable_status_controller()->set_last_get_key_result(SYNCER_OK); | 21 session->mutable_status_controller()->set_last_get_key_result(SYNCER_OK); |
| 28 session->mutable_status_controller()->set_last_download_updates_result( | 22 session->mutable_status_controller()->set_last_download_updates_result( |
| 29 SERVER_RETURN_TRANSIENT_ERROR); | 23 SERVER_RETURN_TRANSIENT_ERROR); |
| 30 } | 24 } |
| 31 | 25 |
| 32 void SimulateCommitFailed(sessions::SyncSession* session, | 26 void SimulateCommitFailed(sessions::SyncSession* session, |
| 33 SyncerStep begin, SyncerStep end) { | 27 SyncerStep begin, SyncerStep end) { |
| 34 session->mutable_status_controller()->set_commit_result( | 28 session->mutable_status_controller()->set_commit_result( |
| 35 SERVER_RETURN_TRANSIENT_ERROR); | 29 SERVER_RETURN_TRANSIENT_ERROR); |
| 36 } | 30 } |
| 37 | 31 |
| 38 void SimulateConnectionFailure(sessions::SyncSession* session, | 32 void SimulateConnectionFailure(sessions::SyncSession* session, |
| 39 SyncerStep begin, SyncerStep end) { | 33 SyncerStep begin, SyncerStep end) { |
| 40 session->mutable_status_controller()->set_last_download_updates_result( | 34 session->mutable_status_controller()->set_last_download_updates_result( |
| 41 NETWORK_CONNECTION_UNAVAILABLE); | 35 NETWORK_CONNECTION_UNAVAILABLE); |
| 42 } | 36 } |
| 43 | 37 |
| 44 void SimulateSuccess(sessions::SyncSession* session, | 38 void SimulateSuccess(sessions::SyncSession* session, |
| 45 SyncerStep begin, SyncerStep end) { | 39 SyncerStep begin, SyncerStep end) { |
| 46 if (session->HasMoreToSync()) { | |
| 47 ADD_FAILURE() << "Shouldn't have more to sync"; | |
| 48 } | |
| 49 ASSERT_EQ(0U, session->status_controller().num_server_changes_remaining()); | 40 ASSERT_EQ(0U, session->status_controller().num_server_changes_remaining()); |
| 50 session->SetFinished(); | 41 session->SetFinished(); |
| 51 switch(end) { | 42 switch(end) { |
| 52 case SYNCER_END: | 43 case SYNCER_END: |
| 53 session->mutable_status_controller()->set_commit_result(SYNCER_OK); | 44 session->mutable_status_controller()->set_commit_result(SYNCER_OK); |
| 54 // Fall through. | 45 // Fall through. |
| 55 case APPLY_UPDATES: | 46 case APPLY_UPDATES: |
| 56 DCHECK_EQ(end == APPLY_UPDATES, session->source().updates_source == | 47 DCHECK_EQ(end == APPLY_UPDATES, session->source().updates_source == |
| 57 sync_pb::GetUpdatesCallerInfo::RECONFIGURATION); | 48 sync_pb::GetUpdatesCallerInfo::RECONFIGURATION); |
| 58 session->mutable_status_controller()->set_last_get_key_result(SYNCER_OK); | 49 session->mutable_status_controller()->set_last_get_key_result(SYNCER_OK); |
| (...skipping 16 matching lines...) Expand all Loading... |
| 75 } | 66 } |
| 76 | 67 |
| 77 void SimulateSessionsCommitDelayUpdateImpl(sessions::SyncSession* session, | 68 void SimulateSessionsCommitDelayUpdateImpl(sessions::SyncSession* session, |
| 78 const base::TimeDelta& new_delay) { | 69 const base::TimeDelta& new_delay) { |
| 79 session->delegate()->OnReceivedSessionsCommitDelay(new_delay); | 70 session->delegate()->OnReceivedSessionsCommitDelay(new_delay); |
| 80 } | 71 } |
| 81 | 72 |
| 82 } // namespace test_util | 73 } // namespace test_util |
| 83 } // namespace sessions | 74 } // namespace sessions |
| 84 } // namespace syncer | 75 } // namespace syncer |
| OLD | NEW |