Index: chrome/browser/extensions/api/storage/settings_sync_unittest.cc |
diff --git a/chrome/browser/extensions/api/storage/settings_sync_unittest.cc b/chrome/browser/extensions/api/storage/settings_sync_unittest.cc |
index 1e54aaf3ddb3f0492199a2f802738b6403ff8b19..5586174721491937bbf0c9127b29511a4fb424fa 100644 |
--- a/chrome/browser/extensions/api/storage/settings_sync_unittest.cc |
+++ b/chrome/browser/extensions/api/storage/settings_sync_unittest.cc |
@@ -20,6 +20,7 @@ |
#include "extensions/browser/extension_system.h" |
#include "extensions/common/manifest.h" |
#include "sync/api/sync_change_processor.h" |
+#include "sync/api/sync_change_processor_delegator.h" |
#include "sync/api/sync_error_factory.h" |
#include "sync/api/sync_error_factory_mock.h" |
#include "testing/gtest/include/gtest/gtest.h" |
@@ -157,33 +158,6 @@ class MockSyncChangeProcessor : public syncer::SyncChangeProcessor { |
bool fail_all_requests_; |
}; |
-class SyncChangeProcessorDelegate : public syncer::SyncChangeProcessor { |
- public: |
- explicit SyncChangeProcessorDelegate(syncer::SyncChangeProcessor* recipient) |
- : recipient_(recipient) { |
- DCHECK(recipient_); |
- } |
- virtual ~SyncChangeProcessorDelegate() {} |
- |
- // syncer::SyncChangeProcessor implementation. |
- virtual syncer::SyncError ProcessSyncChanges( |
- const tracked_objects::Location& from_here, |
- const syncer::SyncChangeList& change_list) OVERRIDE { |
- return recipient_->ProcessSyncChanges(from_here, change_list); |
- } |
- |
- virtual syncer::SyncDataList GetAllSyncData(syncer::ModelType type) const |
- OVERRIDE { |
- return recipient_->GetAllSyncData(type); |
- } |
- |
- private: |
- // The recipient of all sync changes. |
- syncer::SyncChangeProcessor* recipient_; |
- |
- DISALLOW_COPY_AND_ASSIGN(SyncChangeProcessorDelegate); |
-}; |
- |
// SettingsStorageFactory which always returns TestingValueStore objects, |
// and allows individually created objects to be returned. |
class TestingValueStoreFactory : public SettingsStorageFactory { |
@@ -220,8 +194,8 @@ class ExtensionSettingsSyncTest : public testing::Test { |
file_thread_(BrowserThread::FILE, base::MessageLoop::current()), |
storage_factory_(new util::ScopedSettingsStorageFactory()), |
sync_processor_(new MockSyncChangeProcessor), |
- sync_processor_delegate_(new SyncChangeProcessorDelegate( |
- sync_processor_.get())) {} |
+ sync_processor_delegate_( |
+ new syncer::SyncChangeProcessorDelegator(sync_processor_.get())) {} |
virtual void SetUp() OVERRIDE { |
ASSERT_TRUE(temp_dir_.CreateUniqueTempDir()); |
@@ -281,7 +255,7 @@ class ExtensionSettingsSyncTest : public testing::Test { |
scoped_ptr<SettingsFrontend> frontend_; |
scoped_refptr<util::ScopedSettingsStorageFactory> storage_factory_; |
scoped_ptr<MockSyncChangeProcessor> sync_processor_; |
- scoped_ptr<SyncChangeProcessorDelegate> sync_processor_delegate_; |
+ scoped_ptr<syncer::SyncChangeProcessorDelegator> sync_processor_delegate_; |
}; |
// Get a semblance of coverage for both EXTENSION_SETTINGS and APP_SETTINGS |
@@ -693,8 +667,8 @@ TEST_F(ExtensionSettingsSyncTest, ExtensionAndAppSettingsSyncSeparately) { |
sync_data.push_back(settings_sync_util::CreateData( |
"s2", "bar", value2, syncer::APP_SETTINGS)); |
- scoped_ptr<SyncChangeProcessorDelegate> app_settings_delegate_( |
- new SyncChangeProcessorDelegate(sync_processor_.get())); |
+ scoped_ptr<syncer::SyncChangeProcessorDelegator> app_settings_delegate_( |
+ new syncer::SyncChangeProcessorDelegator(sync_processor_.get())); |
GetSyncableService(syncer::APP_SETTINGS)->MergeDataAndStartSyncing( |
syncer::APP_SETTINGS, |
sync_data, |
@@ -846,8 +820,8 @@ TEST_F(ExtensionSettingsSyncTest, FailingStartSyncingDisablesSync) { |
// Restarting sync should make bad start syncing again. |
sync_processor_->ClearChanges(); |
GetSyncableService(model_type)->StopSyncing(model_type); |
- sync_processor_delegate_.reset(new SyncChangeProcessorDelegate( |
- sync_processor_.get())); |
+ sync_processor_delegate_.reset( |
+ new syncer::SyncChangeProcessorDelegator(sync_processor_.get())); |
GetSyncableService(model_type)->MergeDataAndStartSyncing( |
model_type, |
syncer::SyncDataList(), |
@@ -1127,8 +1101,8 @@ TEST_F(ExtensionSettingsSyncTest, FailureToReadChangesToPushDisablesSync) { |
// to be pushed to sync successfully, as should future changes to bad. |
sync_processor_->ClearChanges(); |
GetSyncableService(model_type)->StopSyncing(model_type); |
- sync_processor_delegate_.reset(new SyncChangeProcessorDelegate( |
- sync_processor_.get())); |
+ sync_processor_delegate_.reset( |
+ new syncer::SyncChangeProcessorDelegator(sync_processor_.get())); |
GetSyncableService(model_type)->MergeDataAndStartSyncing( |
model_type, |
syncer::SyncDataList(), |
@@ -1221,8 +1195,8 @@ TEST_F(ExtensionSettingsSyncTest, FailureToPushLocalStateDisablesSync) { |
// Restarting sync makes everything work again. |
sync_processor_->ClearChanges(); |
GetSyncableService(model_type)->StopSyncing(model_type); |
- sync_processor_delegate_.reset(new SyncChangeProcessorDelegate( |
- sync_processor_.get())); |
+ sync_processor_delegate_.reset( |
+ new syncer::SyncChangeProcessorDelegator(sync_processor_.get())); |
GetSyncableService(model_type)->MergeDataAndStartSyncing( |
model_type, |
syncer::SyncDataList(), |
@@ -1318,8 +1292,8 @@ TEST_F(ExtensionSettingsSyncTest, FailureToPushLocalChangeDisablesSync) { |
// Restarting sync makes everything work again. |
sync_processor_->ClearChanges(); |
GetSyncableService(model_type)->StopSyncing(model_type); |
- sync_processor_delegate_.reset(new SyncChangeProcessorDelegate( |
- sync_processor_.get())); |
+ sync_processor_delegate_.reset( |
+ new syncer::SyncChangeProcessorDelegator(sync_processor_.get())); |
GetSyncableService(model_type)->MergeDataAndStartSyncing( |
model_type, |
syncer::SyncDataList(), |