Index: chrome/browser/sync/glue/non_ui_data_type_controller_unittest.cc |
diff --git a/chrome/browser/sync/glue/non_ui_data_type_controller_unittest.cc b/chrome/browser/sync/glue/non_ui_data_type_controller_unittest.cc |
index 4be7a1be32ac9676eb9e14c303ad1fd11d8e23ac..43107dade515d279e5f0f269545ed5a5fa1a1723 100644 |
--- a/chrome/browser/sync/glue/non_ui_data_type_controller_unittest.cc |
+++ b/chrome/browser/sync/glue/non_ui_data_type_controller_unittest.cc |
@@ -189,7 +189,7 @@ class SyncNonUIDataTypeControllerTest : public testing::Test { |
protected: |
void SetStartExpectations() { |
- EXPECT_CALL(*dtc_mock_, StartModels()).WillOnce(Return(true)); |
+ EXPECT_CALL(*dtc_mock_.get(), StartModels()).WillOnce(Return(true)); |
EXPECT_CALL(model_load_callback_, Run(_, _)); |
EXPECT_CALL(*profile_sync_factory_, |
CreateSharedChangeProcessor()). |
@@ -197,17 +197,17 @@ class SyncNonUIDataTypeControllerTest : public testing::Test { |
} |
void SetAssociateExpectations() { |
- EXPECT_CALL(*change_processor_, Connect(_,_,_,_,_)). |
- WillOnce(GetWeakPtrToSyncableService(&syncable_service_)); |
- EXPECT_CALL(*change_processor_, CryptoReadyIfNecessary()). |
- WillOnce(Return(true)); |
- EXPECT_CALL(*change_processor_, ActivateDataType(_)); |
- EXPECT_CALL(*change_processor_, SyncModelHasUserCreatedNodes(_)). |
- WillOnce(DoAll(SetArgumentPointee<0>(true), Return(true))); |
- EXPECT_CALL(*change_processor_, GetSyncData(_)). |
- WillOnce(Return(syncer::SyncError())); |
- EXPECT_CALL(*change_processor_, GetSyncCount()).WillOnce(Return(0)); |
- EXPECT_CALL(*dtc_mock_, RecordAssociationTime(_)); |
+ EXPECT_CALL(*change_processor_.get(), Connect(_, _, _, _, _)) |
+ .WillOnce(GetWeakPtrToSyncableService(&syncable_service_)); |
+ EXPECT_CALL(*change_processor_.get(), CryptoReadyIfNecessary()) |
+ .WillOnce(Return(true)); |
+ EXPECT_CALL(*change_processor_.get(), ActivateDataType(_)); |
+ EXPECT_CALL(*change_processor_.get(), SyncModelHasUserCreatedNodes(_)) |
+ .WillOnce(DoAll(SetArgumentPointee<0>(true), Return(true))); |
+ EXPECT_CALL(*change_processor_.get(), GetSyncData(_)) |
+ .WillOnce(Return(syncer::SyncError())); |
+ EXPECT_CALL(*change_processor_.get(), GetSyncCount()).WillOnce(Return(0)); |
+ EXPECT_CALL(*dtc_mock_.get(), RecordAssociationTime(_)); |
} |
void SetActivateExpectations(DataTypeController::StartResult result) { |
@@ -215,17 +215,17 @@ class SyncNonUIDataTypeControllerTest : public testing::Test { |
} |
void SetStopExpectations() { |
- EXPECT_CALL(*dtc_mock_, StopModels()); |
- EXPECT_CALL(*change_processor_, Disconnect()).WillOnce(Return(true)); |
+ EXPECT_CALL(*dtc_mock_.get(), StopModels()); |
+ EXPECT_CALL(*change_processor_.get(), Disconnect()).WillOnce(Return(true)); |
EXPECT_CALL(service_, DeactivateDataType(_)); |
} |
void SetStartFailExpectations(DataTypeController::StartResult result) { |
- EXPECT_CALL(*dtc_mock_, StopModels()).Times(AtLeast(1)); |
+ EXPECT_CALL(*dtc_mock_.get(), StopModels()).Times(AtLeast(1)); |
if (DataTypeController::IsUnrecoverableResult(result)) |
- EXPECT_CALL(*dtc_mock_, RecordUnrecoverableError(_, _)); |
- EXPECT_CALL(*dtc_mock_, RecordStartFailure(result)); |
- EXPECT_CALL(start_callback_, Run(result,_,_)); |
+ EXPECT_CALL(*dtc_mock_.get(), RecordUnrecoverableError(_, _)); |
+ EXPECT_CALL(*dtc_mock_.get(), RecordStartFailure(result)); |
+ EXPECT_CALL(start_callback_, Run(result, _, _)); |
} |
void Start() { |
@@ -269,15 +269,15 @@ TEST_F(SyncNonUIDataTypeControllerTest, StartOk) { |
TEST_F(SyncNonUIDataTypeControllerTest, StartFirstRun) { |
SetStartExpectations(); |
- EXPECT_CALL(*change_processor_, Connect(_,_,_,_,_)). |
- WillOnce(GetWeakPtrToSyncableService(&syncable_service_)); |
- EXPECT_CALL(*change_processor_, CryptoReadyIfNecessary()). |
- WillOnce(Return(true)); |
- EXPECT_CALL(*change_processor_, SyncModelHasUserCreatedNodes(_)). |
- WillOnce(DoAll(SetArgumentPointee<0>(false), Return(true))); |
- EXPECT_CALL(*change_processor_, GetSyncData(_)). |
- WillOnce(Return(syncer::SyncError())); |
- EXPECT_CALL(*dtc_mock_, RecordAssociationTime(_)); |
+ EXPECT_CALL(*change_processor_.get(), Connect(_, _, _, _, _)) |
+ .WillOnce(GetWeakPtrToSyncableService(&syncable_service_)); |
+ EXPECT_CALL(*change_processor_.get(), CryptoReadyIfNecessary()) |
+ .WillOnce(Return(true)); |
+ EXPECT_CALL(*change_processor_.get(), SyncModelHasUserCreatedNodes(_)) |
+ .WillOnce(DoAll(SetArgumentPointee<0>(false), Return(true))); |
+ EXPECT_CALL(*change_processor_.get(), GetSyncData(_)) |
+ .WillOnce(Return(syncer::SyncError())); |
+ EXPECT_CALL(*dtc_mock_.get(), RecordAssociationTime(_)); |
SetActivateExpectations(DataTypeController::OK_FIRST_RUN); |
EXPECT_EQ(DataTypeController::NOT_RUNNING, non_ui_dtc_->state()); |
Start(); |
@@ -291,8 +291,8 @@ TEST_F(SyncNonUIDataTypeControllerTest, AbortDuringStartModels) { |
EXPECT_CALL(*profile_sync_factory_, |
CreateSharedChangeProcessor()). |
WillOnce(Return(change_processor_.get())); |
- EXPECT_CALL(*dtc_mock_, StartModels()).WillOnce(Return(false)); |
- EXPECT_CALL(*dtc_mock_, StopModels()); |
+ EXPECT_CALL(*dtc_mock_.get(), StartModels()).WillOnce(Return(false)); |
+ EXPECT_CALL(*dtc_mock_.get(), StopModels()); |
EXPECT_CALL(model_load_callback_, Run(_, _)); |
EXPECT_EQ(DataTypeController::NOT_RUNNING, non_ui_dtc_->state()); |
non_ui_dtc_->LoadModels( |
@@ -309,15 +309,15 @@ TEST_F(SyncNonUIDataTypeControllerTest, AbortDuringStartModels) { |
// cleanly. |
TEST_F(SyncNonUIDataTypeControllerTest, StartAssociationFailed) { |
SetStartExpectations(); |
- EXPECT_CALL(*change_processor_, Connect(_,_,_,_,_)). |
- WillOnce(GetWeakPtrToSyncableService(&syncable_service_)); |
- EXPECT_CALL(*change_processor_, CryptoReadyIfNecessary()). |
- WillOnce(Return(true)); |
- EXPECT_CALL(*change_processor_, SyncModelHasUserCreatedNodes(_)). |
- WillOnce(DoAll(SetArgumentPointee<0>(true), Return(true))); |
- EXPECT_CALL(*change_processor_, GetSyncData(_)). |
- WillOnce(Return(syncer::SyncError())); |
- EXPECT_CALL(*dtc_mock_, RecordAssociationTime(_)); |
+ EXPECT_CALL(*change_processor_.get(), Connect(_, _, _, _, _)) |
+ .WillOnce(GetWeakPtrToSyncableService(&syncable_service_)); |
+ EXPECT_CALL(*change_processor_.get(), CryptoReadyIfNecessary()) |
+ .WillOnce(Return(true)); |
+ EXPECT_CALL(*change_processor_.get(), SyncModelHasUserCreatedNodes(_)) |
+ .WillOnce(DoAll(SetArgumentPointee<0>(true), Return(true))); |
+ EXPECT_CALL(*change_processor_.get(), GetSyncData(_)) |
+ .WillOnce(Return(syncer::SyncError())); |
+ EXPECT_CALL(*dtc_mock_.get(), RecordAssociationTime(_)); |
SetStartFailExpectations(DataTypeController::ASSOCIATION_FAILED); |
// Set up association to fail with an association failed error. |
EXPECT_EQ(DataTypeController::NOT_RUNNING, non_ui_dtc_->state()); |
@@ -336,12 +336,12 @@ TEST_F(SyncNonUIDataTypeControllerTest, |
SetStartExpectations(); |
SetStartFailExpectations(DataTypeController::UNRECOVERABLE_ERROR); |
// Set up association to fail with an unrecoverable error. |
- EXPECT_CALL(*change_processor_, Connect(_,_,_,_,_)). |
- WillOnce(GetWeakPtrToSyncableService(&syncable_service_)); |
- EXPECT_CALL(*change_processor_, CryptoReadyIfNecessary()). |
- WillRepeatedly(Return(true)); |
- EXPECT_CALL(*change_processor_, SyncModelHasUserCreatedNodes(_)). |
- WillRepeatedly(DoAll(SetArgumentPointee<0>(false), Return(false))); |
+ EXPECT_CALL(*change_processor_.get(), Connect(_, _, _, _, _)) |
+ .WillOnce(GetWeakPtrToSyncableService(&syncable_service_)); |
+ EXPECT_CALL(*change_processor_.get(), CryptoReadyIfNecessary()) |
+ .WillRepeatedly(Return(true)); |
+ EXPECT_CALL(*change_processor_.get(), SyncModelHasUserCreatedNodes(_)) |
+ .WillRepeatedly(DoAll(SetArgumentPointee<0>(false), Return(false))); |
EXPECT_EQ(DataTypeController::NOT_RUNNING, non_ui_dtc_->state()); |
Start(); |
WaitForDTC(); |
@@ -353,10 +353,10 @@ TEST_F(SyncNonUIDataTypeControllerTest, |
SetStartExpectations(); |
SetStartFailExpectations(DataTypeController::NEEDS_CRYPTO); |
// Set up association to fail with a NEEDS_CRYPTO error. |
- EXPECT_CALL(*change_processor_, Connect(_,_,_,_,_)). |
- WillOnce(GetWeakPtrToSyncableService(&syncable_service_)); |
- EXPECT_CALL(*change_processor_, CryptoReadyIfNecessary()). |
- WillRepeatedly(Return(false)); |
+ EXPECT_CALL(*change_processor_.get(), Connect(_, _, _, _, _)) |
+ .WillOnce(GetWeakPtrToSyncableService(&syncable_service_)); |
+ EXPECT_CALL(*change_processor_.get(), CryptoReadyIfNecessary()) |
+ .WillRepeatedly(Return(false)); |
EXPECT_EQ(DataTypeController::NOT_RUNNING, non_ui_dtc_->state()); |
Start(); |
WaitForDTC(); |
@@ -371,22 +371,19 @@ TEST_F(SyncNonUIDataTypeControllerTest, AbortDuringAssociation) { |
SetStartExpectations(); |
SetStartFailExpectations(DataTypeController::ABORTED); |
- EXPECT_CALL(*change_processor_, Connect(_,_,_,_,_)). |
- WillOnce(GetWeakPtrToSyncableService(&syncable_service_)); |
- EXPECT_CALL(*change_processor_, CryptoReadyIfNecessary()). |
- WillOnce(Return(true)); |
- EXPECT_CALL(*change_processor_, SyncModelHasUserCreatedNodes(_)). |
- WillOnce(DoAll( |
- SignalEvent(&wait_for_db_thread_pause), |
- WaitOnEvent(&pause_db_thread), |
- SetArgumentPointee<0>(true), |
- Return(true))); |
- EXPECT_CALL(*change_processor_, GetSyncData(_)). |
- WillOnce( |
- Return( |
- syncer::SyncError(FROM_HERE, "Disconnected.", AUTOFILL_PROFILE))); |
- EXPECT_CALL(*change_processor_, Disconnect()). |
- WillOnce(DoAll(SignalEvent(&pause_db_thread), Return(true))); |
+ EXPECT_CALL(*change_processor_.get(), Connect(_, _, _, _, _)) |
+ .WillOnce(GetWeakPtrToSyncableService(&syncable_service_)); |
+ EXPECT_CALL(*change_processor_.get(), CryptoReadyIfNecessary()) |
+ .WillOnce(Return(true)); |
+ EXPECT_CALL(*change_processor_.get(), SyncModelHasUserCreatedNodes(_)) |
+ .WillOnce(DoAll(SignalEvent(&wait_for_db_thread_pause), |
+ WaitOnEvent(&pause_db_thread), |
+ SetArgumentPointee<0>(true), |
+ Return(true))); |
+ EXPECT_CALL(*change_processor_.get(), GetSyncData(_)).WillOnce( |
+ Return(syncer::SyncError(FROM_HERE, "Disconnected.", AUTOFILL_PROFILE))); |
+ EXPECT_CALL(*change_processor_.get(), Disconnect()) |
+ .WillOnce(DoAll(SignalEvent(&pause_db_thread), Return(true))); |
EXPECT_CALL(service_, DeactivateDataType(_)); |
EXPECT_EQ(DataTypeController::NOT_RUNNING, non_ui_dtc_->state()); |
Start(); |
@@ -405,10 +402,11 @@ TEST_F(SyncNonUIDataTypeControllerTest, StartAfterSyncShutdown) { |
SetStartExpectations(); |
// We don't expect StopSyncing to be called because local_service_ will never |
// have been set. |
- EXPECT_CALL(*change_processor_, Disconnect()).WillOnce(Return(true)); |
- EXPECT_CALL(*dtc_mock_, StopModels()); |
+ EXPECT_CALL(*change_processor_.get(), Disconnect()).WillOnce(Return(true)); |
+ EXPECT_CALL(*dtc_mock_.get(), StopModels()); |
EXPECT_CALL(service_, DeactivateDataType(_)); |
- EXPECT_CALL(*dtc_mock_, RecordStartFailure(DataTypeController::ABORTED)); |
+ EXPECT_CALL(*dtc_mock_.get(), |
+ RecordStartFailure(DataTypeController::ABORTED)); |
EXPECT_CALL(start_callback_, Run(DataTypeController::ABORTED, _, _)); |
EXPECT_EQ(DataTypeController::NOT_RUNNING, non_ui_dtc_->state()); |
Start(); |
@@ -416,11 +414,11 @@ TEST_F(SyncNonUIDataTypeControllerTest, StartAfterSyncShutdown) { |
EXPECT_EQ(DataTypeController::NOT_RUNNING, non_ui_dtc_->state()); |
Mock::VerifyAndClearExpectations(&profile_sync_factory_); |
Mock::VerifyAndClearExpectations(&service_); |
- Mock::VerifyAndClearExpectations(change_processor_); |
- Mock::VerifyAndClearExpectations(dtc_mock_); |
+ Mock::VerifyAndClearExpectations(change_processor_.get()); |
+ Mock::VerifyAndClearExpectations(dtc_mock_.get()); |
- EXPECT_CALL(*change_processor_, Connect(_,_,_,_,_)). |
- WillOnce(Return(base::WeakPtr<syncer::SyncableService>())); |
+ EXPECT_CALL(*change_processor_.get(), Connect(_, _, _, _, _)) |
+ .WillOnce(Return(base::WeakPtr<syncer::SyncableService>())); |
non_ui_dtc_->UnblockBackendTasks(); |
WaitForDTC(); |
} |
@@ -471,10 +469,9 @@ TEST_F(SyncNonUIDataTypeControllerTest, |
SetStartExpectations(); |
SetAssociateExpectations(); |
SetActivateExpectations(DataTypeController::OK); |
- EXPECT_CALL(*dtc_mock_, RecordUnrecoverableError(_, "Test")); |
- EXPECT_CALL(service_, DisableBrokenDatatype(_,_,_)).WillOnce( |
- InvokeWithoutArgs(non_ui_dtc_.get(), |
- &NonUIDataTypeController::Stop)); |
+ EXPECT_CALL(*dtc_mock_.get(), RecordUnrecoverableError(_, "Test")); |
+ EXPECT_CALL(service_, DisableBrokenDatatype(_, _, _)).WillOnce( |
+ InvokeWithoutArgs(non_ui_dtc_.get(), &NonUIDataTypeController::Stop)); |
SetStopExpectations(); |
EXPECT_EQ(DataTypeController::NOT_RUNNING, non_ui_dtc_->state()); |
Start(); |