| 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(),
|
|
|