[SyncFS] Wire up LocalChangeProcessor to SyncTask

chrome/browser/sync_file_system/drive_backend/sync_engine.cc

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/sync_file_system/drive_backend/sync_engine.h"
 
 #include "base/bind.h"
 #include "base/values.h"
 #include "chrome/browser/drive/drive_api_service.h"
 #include "chrome/browser/drive/drive_notification_manager.h"
@@ skipping 101 matching lines @@
     const GURL& origin,
     UninstallFlag flag,
     const SyncStatusCallback& callback) {
   task_manager_->ScheduleSyncTask(
       scoped_ptr<SyncTask>(new UninstallAppTask(this, origin.host(), flag)),
       callback);
 }
 
 void SyncEngine::ProcessRemoteChange(
     const SyncFileCallback& callback) {
-  RemoteToLocalSyncer* syncer = new RemoteToLocalSyncer;
+  RemoteToLocalSyncer* syncer = new RemoteToLocalSyncer(this);
   task_manager_->ScheduleSyncTask(
       scoped_ptr<SyncTask>(syncer),
       base::Bind(&SyncEngine::DidProcessRemoteChange,
                  weak_ptr_factory_.GetWeakPtr(),
                  syncer, callback));
 }
 
 void SyncEngine::SetRemoteChangeProcessor(
     RemoteChangeProcessor* processor) {
   remote_change_processor_ = processor;
@@ skipping 61 matching lines @@
     const DownloadVersionCallback& callback) {
   NOTIMPLEMENTED();
 }
 
 void SyncEngine::ApplyLocalChange(
     const FileChange& local_file_change,
     const base::FilePath& local_file_path,
     const SyncFileMetadata& local_file_metadata,
     const fileapi::FileSystemURL& url,
     const SyncStatusCallback& callback) {
-  LocalToRemoteSyncer* syncer = new LocalToRemoteSyncer;
+  LocalToRemoteSyncer* syncer = new LocalToRemoteSyncer(this);
   task_manager_->ScheduleSyncTask(
       scoped_ptr<SyncTask>(syncer),
       base::Bind(&SyncEngine::DidApplyLocalChange,
                  weak_ptr_factory_.GetWeakPtr(),
                  syncer, callback));
 }
 
 void SyncEngine::MaybeScheduleNextTask() {
   if (GetCurrentState() == REMOTE_SERVICE_DISABLED)
     return;
@@ skipping 47 matching lines @@
 }
 
 drive::DriveServiceInterface* SyncEngine::GetDriveService() {
   return drive_service_.get();
 }
 
 MetadataDatabase* SyncEngine::GetMetadataDatabase() {
   return metadata_database_.get();
 }
 
+RemoteChangeProcessor* SyncEngine::GetRemoteChangeProcessor() {
+  return remote_change_processor_;
+}
+
 void SyncEngine::DoDisableApp(const std::string& app_id,
                               const SyncStatusCallback& callback) {
   NOTIMPLEMENTED();
 }
 
 void SyncEngine::DoEnableApp(const std::string& app_id,
                              const SyncStatusCallback& callback) {
   NOTIMPLEMENTED();
 }
 
@@ skipping 48 matching lines @@
   util::Log(logging::LOG_INFO, FROM_HERE,
             "Service state changed: %d->%d: %s",
             old_state, GetCurrentState(), description.c_str());
   FOR_EACH_OBSERVER(
       Observer, service_observers_,
       OnRemoteServiceStateUpdated(GetCurrentState(), description));
 }
 
 }  // namespace drive_backend
 }  // namespace sync_file_system