sync_file_system_service.cc revision 5f1c94371a64b3196d4be9466099bb892df9b88e
15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2012 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "chrome/browser/sync_file_system/sync_file_system_service.h" 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 72a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include <string> 82a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/bind.h" 107d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)#include "base/format_macros.h" 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/logging.h" 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/memory/ref_counted.h" 13a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles)#include "base/metrics/histogram.h" 14116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch#include "base/single_thread_task_runner.h" 152a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "base/stl_util.h" 16116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch#include "base/thread_task_runner_handle.h" 172a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "chrome/browser/extensions/api/sync_file_system/extension_sync_event_observer.h" 187dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch#include "chrome/browser/extensions/api/sync_file_system/sync_file_system_api_helpers.h" 195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "chrome/browser/profiles/profile.h" 202a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "chrome/browser/sync/profile_sync_service.h" 212a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "chrome/browser/sync/profile_sync_service_factory.h" 222385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch#include "chrome/browser/sync_file_system/local/local_file_sync_service.h" 2390dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles)#include "chrome/browser/sync_file_system/logger.h" 24eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch#include "chrome/browser/sync_file_system/sync_direction.h" 252a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "chrome/browser/sync_file_system/sync_event_observer.h" 262385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch#include "chrome/browser/sync_file_system/sync_file_metadata.h" 27a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)#include "chrome/browser/sync_file_system/sync_process_runner.h" 282385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch#include "chrome/browser/sync_file_system/sync_status_code.h" 292385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch#include "chrome/browser/sync_file_system/syncable_file_system_util.h" 30a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles)#include "components/keyed_service/content/browser_context_dependency_manager.h" 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "content/public/browser/browser_thread.h" 327dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch#include "content/public/browser/storage_partition.h" 335d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "extensions/browser/extension_prefs.h" 34116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch#include "extensions/browser/extension_registry.h" 35f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles)#include "extensions/common/extension.h" 3668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)#include "extensions/common/manifest_constants.h" 37eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch#include "url/gurl.h" 3890dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles)#include "webkit/browser/fileapi/file_system_context.h" 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)using content::BrowserThread; 41d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)using extensions::Extension; 42d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)using extensions::ExtensionPrefs; 43116680a4aac90f2aa7413d9095a592090648e557Ben Murdochusing extensions::ExtensionRegistry; 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)using fileapi::FileSystemURL; 452a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)using fileapi::FileSystemURLSet; 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace sync_file_system { 485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)namespace { 502a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 51a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)const char kLocalSyncName[] = "Local sync"; 52a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)const char kRemoteSyncName[] = "Remote sync"; 53a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)const char kRemoteSyncNameV2[] = "Remote sync (v2)"; 54c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 55c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles)SyncServiceState RemoteStateToSyncServiceState( 562a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) RemoteServiceState state) { 572a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) switch (state) { 582a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) case REMOTE_SERVICE_OK: 59c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return SYNC_SERVICE_RUNNING; 602a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) case REMOTE_SERVICE_TEMPORARY_UNAVAILABLE: 61c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return SYNC_SERVICE_TEMPORARY_UNAVAILABLE; 622a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) case REMOTE_SERVICE_AUTHENTICATION_REQUIRED: 63c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return SYNC_SERVICE_AUTHENTICATION_REQUIRED; 642a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) case REMOTE_SERVICE_DISABLED: 65c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return SYNC_SERVICE_DISABLED; 66a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) case REMOTE_SERVICE_STATE_MAX: 67a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) NOTREACHED(); 682a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 69c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) NOTREACHED() << "Unknown remote service state: " << state; 70c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return SYNC_SERVICE_DISABLED; 712a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 722a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 73116680a4aac90f2aa7413d9095a592090648e557Ben Murdochvoid DidHandleUninstalledEvent(const GURL& origin, SyncStatusCode code) { 74116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch if (code != SYNC_STATUS_OK && code != SYNC_STATUS_UNKNOWN_ORIGIN) { 75116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch util::Log(logging::LOG_WARNING, FROM_HERE, 76116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch "Failed to uninstall origin for uninstall event: %s", 77116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch origin.spec().c_str()); 78116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch } 79116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch} 80116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch 81116680a4aac90f2aa7413d9095a592090648e557Ben Murdochvoid DidHandleUnloadedEvent(const GURL& origin, SyncStatusCode code) { 82116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch if (code != SYNC_STATUS_OK && code != SYNC_STATUS_UNKNOWN_ORIGIN) { 83116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch util::Log(logging::LOG_WARNING, FROM_HERE, 84116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch "Failed to disable origin for unload event: %s", 85116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch origin.spec().c_str()); 862a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 872a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 882a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 89116680a4aac90f2aa7413d9095a592090648e557Ben Murdochvoid DidHandleLoadEvent( 902a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const GURL& origin, 912a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncStatusCode code) { 92116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch if (code != SYNC_STATUS_OK) { 93116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch util::Log(logging::LOG_WARNING, FROM_HERE, 94116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch "Failed to enable origin for load event: %s", 9590dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) origin.spec().c_str()); 96116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch } 972a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 982a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 997dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdochstd::string SyncFileStatusToString(SyncFileStatus sync_file_status) { 1007dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch return extensions::api::sync_file_system::ToString( 1017dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch extensions::SyncFileStatusToExtensionEnum(sync_file_status)); 1027dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch} 1037dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 1047d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)// Gets called repeatedly until every SyncFileStatus has been mapped. 1057dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdochvoid DidGetFileSyncStatusForDump( 1067dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::ListValue* files, 1077d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) size_t* num_results, 1087dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch const SyncFileSystemService::DumpFilesCallback& callback, 1097dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::DictionaryValue* file, 1107d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) SyncStatusCode sync_status_code, 1117d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) SyncFileStatus sync_file_status) { 1127dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch DCHECK(files); 1137d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) DCHECK(num_results); 1147d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 1157dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (file) 1167dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch file->SetString("status", SyncFileStatusToString(sync_file_status)); 1177d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 1187d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) // Once all results have been received, run the callback to signal end. 1197dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch DCHECK_LE(*num_results, files->GetSize()); 1207dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (++*num_results < files->GetSize()) 1217d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) return; 1227d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 123cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) callback.Run(*files); 1247d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)} 1257d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 126a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)// We need this indirection because WeakPtr can only be bound to methods 127a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)// without a return value. 128a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)LocalChangeProcessor* GetLocalChangeProcessorAdapter( 129a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::WeakPtr<SyncFileSystemService> service, 130a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const GURL& origin) { 131a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (!service) 132a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return NULL; 133a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return service->GetLocalChangeProcessor(origin); 134a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)} 1352a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 136a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)} // namespace 137d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 138a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)//--------------------------------------------------------------------------- 139a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)// SyncProcessRunner's. 140d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 141a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)// SyncProcessRunner implementation for LocalSync. 142a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)class LocalSyncRunner : public SyncProcessRunner, 143a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) public LocalFileSyncService::Observer { 144a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) public: 145a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) LocalSyncRunner(const std::string& name, 146a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) SyncFileSystemService* sync_service) 147116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch : SyncProcessRunner(name, sync_service, 148116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch scoped_ptr<SyncProcessRunner::TimerHelper>(), 1), 149a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) factory_(this) {} 150a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 151a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void StartSync(const SyncStatusCallback& callback) OVERRIDE { 152116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch GetSyncService()->local_service_->ProcessLocalChange( 153a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::Bind(&LocalSyncRunner::DidProcessLocalChange, 154a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) factory_.GetWeakPtr(), callback)); 155d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) } 156d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 157a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // LocalFileSyncService::Observer overrides. 158a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void OnLocalChangeAvailable(int64 pending_changes) OVERRIDE { 159a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 160d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 161a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) OnChangesUpdated(pending_changes); 162d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 163a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Kick other sync runners just in case they're not running. 164116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch GetSyncService()->RunForEachSyncRunners(&SyncProcessRunner::Schedule); 165a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 166d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 167d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) private: 168a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) void DidProcessLocalChange( 169a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const SyncStatusCallback& callback, 170a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) SyncStatusCode status, 171a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const FileSystemURL& url) { 172d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) util::Log(logging::LOG_VERBOSE, FROM_HERE, 173a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) "ProcessLocalChange finished with status=%d (%s) for url=%s", 174a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) status, SyncStatusCodeToString(status), 175a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) url.DebugString().c_str()); 176a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) callback.Run(status); 177d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) } 178d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 179a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::WeakPtrFactory<LocalSyncRunner> factory_; 180a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(LocalSyncRunner); 181a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)}; 182d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 183a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)// SyncProcessRunner implementation for RemoteSync. 184a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)class RemoteSyncRunner : public SyncProcessRunner, 185a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) public RemoteFileSyncService::Observer { 186a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) public: 187a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) RemoteSyncRunner(const std::string& name, 188a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) SyncFileSystemService* sync_service, 189a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) RemoteFileSyncService* remote_service) 190116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch : SyncProcessRunner(name, sync_service, 191116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch scoped_ptr<SyncProcessRunner::TimerHelper>(), 1), 192a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_(remote_service), 193a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) last_state_(REMOTE_SERVICE_OK), 194a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) factory_(this) {} 195a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 196a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void StartSync(const SyncStatusCallback& callback) OVERRIDE { 197a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_->ProcessRemoteChange( 198a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::Bind(&RemoteSyncRunner::DidProcessRemoteChange, 199a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) factory_.GetWeakPtr(), callback)); 200a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 201d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 202a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual SyncServiceState GetServiceState() OVERRIDE { 203a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return RemoteStateToSyncServiceState(last_state_); 204d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) } 205d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 206a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // RemoteFileSyncService::Observer overrides. 207a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void OnRemoteChangeQueueUpdated(int64 pending_changes) OVERRIDE { 208a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 209d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 210a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) OnChangesUpdated(pending_changes); 211d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 212a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Kick other sync runners just in case they're not running. 213116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch GetSyncService()->RunForEachSyncRunners(&SyncProcessRunner::Schedule); 214a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 215d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 216a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void OnRemoteServiceStateUpdated( 217a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) RemoteServiceState state, 218a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const std::string& description) OVERRIDE { 219a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Just forward to SyncFileSystemService. 220116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch GetSyncService()->OnRemoteServiceStateUpdated(state, description); 221a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) last_state_ = state; 222a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 223d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 224a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) private: 225a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) void DidProcessRemoteChange( 226a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const SyncStatusCallback& callback, 227a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) SyncStatusCode status, 228a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const FileSystemURL& url) { 229a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) util::Log(logging::LOG_VERBOSE, FROM_HERE, 230a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) "ProcessRemoteChange finished with status=%d (%s) for url=%s", 231a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) status, SyncStatusCodeToString(status), 232a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) url.DebugString().c_str()); 233a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 234a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (status == SYNC_STATUS_FILE_BUSY) { 235116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch GetSyncService()->local_service_->RegisterURLForWaitingSync( 236a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) url, base::Bind(&RemoteSyncRunner::Schedule, 237a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) factory_.GetWeakPtr())); 238a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 239a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) callback.Run(status); 240d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) } 241d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 242d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) RemoteFileSyncService* remote_service_; 243a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) RemoteServiceState last_state_; 244a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::WeakPtrFactory<RemoteSyncRunner> factory_; 245a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(RemoteSyncRunner); 246d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)}; 247d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 248d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)//----------------------------------------------------------------------------- 249a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)// SyncFileSystemService 250d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 2515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void SyncFileSystemService::Shutdown() { 2525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 2535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 254116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch local_sync_runners_.clear(); 255116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch remote_sync_runners_.clear(); 256116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch 257a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->Shutdown(); 258a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_.reset(); 2595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 260a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_.reset(); 261a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_.reset(); 2625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2632a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceBase* profile_sync_service = 2642a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceFactory::GetForProfile(profile_); 2652a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (profile_sync_service) 2662a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) profile_sync_service->RemoveObserver(this); 2672a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 268116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch ExtensionRegistry::Get(profile_)->RemoveObserver(this); 269116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch 2705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) profile_ = NULL; 2715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SyncFileSystemService::~SyncFileSystemService() { 2745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 2755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!profile_); 2765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void SyncFileSystemService::InitializeForApp( 2795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fileapi::FileSystemContext* file_system_context, 2805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const GURL& app_origin, 2815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const SyncStatusCallback& callback) { 282a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(local_service_); 283a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(remote_service_); 2845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(app_origin == app_origin.GetOrigin()); 2855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2867d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) util::Log(logging::LOG_VERBOSE, FROM_HERE, 2877d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) "Initializing for App: %s", app_origin.spec().c_str()); 2885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 289a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->MaybeInitializeFileSystemContext( 290868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) app_origin, file_system_context, 2912a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::Bind(&SyncFileSystemService::DidInitializeFileSystem, 2922a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) AsWeakPtr(), app_origin, callback)); 2932a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 2945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 295868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)void SyncFileSystemService::GetExtensionStatusMap( 296cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) const ExtensionStatusMapCallback& callback) { 297cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) remote_service_->GetOriginStatusMap( 298cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) base::Bind(&SyncFileSystemService::DidGetExtensionStatusMap, 299cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) AsWeakPtr(), callback)); 300868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)} 301868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 3027dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdochvoid SyncFileSystemService::DumpFiles(const GURL& origin, 3037dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch const DumpFilesCallback& callback) { 304eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch DCHECK(!origin.is_empty()); 3057d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 3067dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch content::StoragePartition* storage_partition = 3077dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch content::BrowserContext::GetStoragePartitionForSite(profile_, origin); 3087dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch fileapi::FileSystemContext* file_system_context = 3097dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch storage_partition->GetFileSystemContext(); 310a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->MaybeInitializeFileSystemContext( 3117dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch origin, file_system_context, 3127dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::Bind(&SyncFileSystemService::DidInitializeFileSystemForDump, 3137dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch AsWeakPtr(), origin, callback)); 3147d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)} 3157d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 316cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)void SyncFileSystemService::DumpDatabase(const DumpFilesCallback& callback) { 317cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) remote_service_->DumpDatabase( 318cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) base::Bind(&SyncFileSystemService::DidDumpDatabase, 319cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) AsWeakPtr(), callback)); 320a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)} 321a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 3222a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::GetFileSyncStatus( 3232a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const FileSystemURL& url, const SyncFileStatusCallback& callback) { 324a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(local_service_); 325a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(GetRemoteService(url.origin())); 3262a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 3272a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // It's possible to get an invalid FileEntry. 3282a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (!url.is_valid()) { 329116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch base::ThreadTaskRunnerHandle::Get()->PostTask( 3302a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) FROM_HERE, 3312a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::Bind(callback, 3322a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SYNC_FILE_ERROR_INVALID_URL, 3332a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SYNC_FILE_STATUS_UNKNOWN)); 3342a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) return; 3355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 3365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 337a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->HasPendingLocalChanges( 3382a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) url, 3392a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::Bind(&SyncFileSystemService::DidGetLocalChangeStatus, 3402a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) AsWeakPtr(), callback)); 3415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3432a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::AddSyncEventObserver(SyncEventObserver* observer) { 3442a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) observers_.AddObserver(observer); 3452a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 3465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3472a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::RemoveSyncEventObserver( 3482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncEventObserver* observer) { 3492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) observers_.RemoveObserver(observer); 3505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 352a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)LocalChangeProcessor* SyncFileSystemService::GetLocalChangeProcessor( 353a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const GURL& origin) { 354a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return GetRemoteService(origin)->GetLocalChangeProcessor(); 3555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 357116680a4aac90f2aa7413d9095a592090648e557Ben Murdochvoid SyncFileSystemService::OnSyncIdle() { 358116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch int64 remote_changes = 0; 359116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch for (ScopedVector<SyncProcessRunner>::iterator iter = 360116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch remote_sync_runners_.begin(); 361116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch iter != remote_sync_runners_.end(); ++iter) 362116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch remote_changes += (*iter)->pending_changes(); 363116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch if (remote_changes == 0) 3645f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) local_service_->PromoteDemotedChanges(NoopClosure()); 365116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch 366116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch int64 local_changes = 0; 367116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch for (ScopedVector<SyncProcessRunner>::iterator iter = 368116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch local_sync_runners_.begin(); 369116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch iter != local_sync_runners_.end(); ++iter) 370116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch local_changes += (*iter)->pending_changes(); 371116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch if (local_changes == 0 && v2_remote_service_) 3725f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) v2_remote_service_->PromoteDemotedChanges(NoopClosure()); 373116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch} 374116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch 375116680a4aac90f2aa7413d9095a592090648e557Ben MurdochSyncServiceState SyncFileSystemService::GetSyncServiceState() { 376116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch // For now we always query the state from the main RemoteFileSyncService. 377116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch return RemoteStateToSyncServiceState(remote_service_->GetCurrentState()); 378116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch} 379116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch 380116680a4aac90f2aa7413d9095a592090648e557Ben MurdochSyncFileSystemService* SyncFileSystemService::GetSyncService() { 381116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch return this; 382116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch} 383116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch 3845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SyncFileSystemService::SyncFileSystemService(Profile* profile) 3855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) : profile_(profile), 3862a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) sync_enabled_(true) { 3872a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 3885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void SyncFileSystemService::Initialize( 390a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) scoped_ptr<LocalFileSyncService> local_service, 391a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) scoped_ptr<RemoteFileSyncService> remote_service) { 3925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 393a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(local_service); 394a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(remote_service); 3955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(profile_); 3965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 397a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_ = local_service.Pass(); 398a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_ = remote_service.Pass(); 3995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 400a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) scoped_ptr<LocalSyncRunner> local_syncer( 401a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) new LocalSyncRunner(kLocalSyncName, this)); 402a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) scoped_ptr<RemoteSyncRunner> remote_syncer( 403a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) new RemoteSyncRunner(kRemoteSyncName, this, remote_service_.get())); 4042a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 405a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->AddChangeObserver(local_syncer.get()); 406a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->SetLocalChangeProcessorCallback( 407a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::Bind(&GetLocalChangeProcessorAdapter, AsWeakPtr())); 4082a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 409a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_->AddServiceObserver(remote_syncer.get()); 410a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_->AddFileStatusObserver(this); 411a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_->SetRemoteChangeProcessor(local_service_.get()); 412a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 4135d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) local_sync_runners_.push_back(local_syncer.release()); 4145d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) remote_sync_runners_.push_back(remote_syncer.release()); 415d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 4162a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceBase* profile_sync_service = 4172a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceFactory::GetForProfile(profile_); 4182a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (profile_sync_service) { 4192a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) UpdateSyncEnabledStatus(profile_sync_service); 4202a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) profile_sync_service->AddObserver(this); 4212a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 4222a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 423116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch ExtensionRegistry::Get(profile_)->AddObserver(this); 4245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4262a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::DidInitializeFileSystem( 4272a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const GURL& app_origin, 4282a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const SyncStatusCallback& callback, 4292a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncStatusCode status) { 4302a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) DVLOG(1) << "DidInitializeFileSystem: " 4312a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) << app_origin.spec() << " " << status; 4322a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 4332a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (status != SYNC_STATUS_OK) { 4342a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) callback.Run(status); 4352a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) return; 4362a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 4375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4382a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Local side of initialization for the app is done. 4392a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Continue on initializing the remote side. 440a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) GetRemoteService(app_origin)->RegisterOrigin( 4412a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) app_origin, 4422a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::Bind(&SyncFileSystemService::DidRegisterOrigin, 4432a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) AsWeakPtr(), app_origin, callback)); 4445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4462a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::DidRegisterOrigin( 4472a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const GURL& app_origin, 4482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const SyncStatusCallback& callback, 4492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncStatusCode status) { 45058537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) util::Log(logging::LOG_VERBOSE, FROM_HERE, 45158537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) "DidInitializeForApp (registered the origin): %s: %s", 45258537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) app_origin.spec().c_str(), 45358537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) SyncStatusCodeToString(status)); 4542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 455a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) UMA_HISTOGRAM_ENUMERATION("SyncFileSystem.RegisterOriginResult", 456a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) GetRemoteService(app_origin)->GetCurrentState(), 457a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) REMOTE_SERVICE_STATE_MAX); 458a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) 459a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (status == SYNC_STATUS_FAILED) { 460a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // If we got generic error return the service status information. 461a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) switch (GetRemoteService(app_origin)->GetCurrentState()) { 462a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) case REMOTE_SERVICE_AUTHENTICATION_REQUIRED: 463a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) callback.Run(SYNC_STATUS_AUTHENTICATION_FAILED); 464a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return; 465a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) case REMOTE_SERVICE_TEMPORARY_UNAVAILABLE: 466a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) callback.Run(SYNC_STATUS_SERVICE_TEMPORARILY_UNAVAILABLE); 467a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return; 468a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) default: 469a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) break; 470a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 471a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 472a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 4732a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) callback.Run(status); 4745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4767dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdochvoid SyncFileSystemService::DidInitializeFileSystemForDump( 4777dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch const GURL& origin, 4787dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch const DumpFilesCallback& callback, 4797dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch SyncStatusCode status) { 4807dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch DCHECK(!origin.is_empty()); 4817dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 4827dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (status != SYNC_STATUS_OK) { 483cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) callback.Run(base::ListValue()); 4847dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch return; 4857dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch } 4867dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 487cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) GetRemoteService(origin)->DumpFiles( 488cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) origin, 489cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) base::Bind( 490cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) &SyncFileSystemService::DidDumpFiles, 491cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) AsWeakPtr(), 492cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) origin, 493cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) callback)); 494cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)} 4955d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 496cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)void SyncFileSystemService::DidDumpFiles( 497cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) const GURL& origin, 498cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) const DumpFilesCallback& callback, 499cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) scoped_ptr<base::ListValue> dump_files) { 500cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) if (!dump_files || !dump_files->GetSize()) { 501cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) callback.Run(base::ListValue()); 5027dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch return; 5037dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch } 5047dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 505cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) base::ListValue* files = dump_files.get(); 506cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) base::Callback<void(base::DictionaryValue*, 507cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) SyncStatusCode, 508cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) SyncFileStatus)> completion_callback = 509cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) base::Bind(&DidGetFileSyncStatusForDump, 510cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) base::Owned(dump_files.release()), 511cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) base::Owned(new size_t(0)), 512cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) callback); 5137dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 5147dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch // After all metadata loaded, sync status can be added to each entry. 5157dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch for (size_t i = 0; i < files->GetSize(); ++i) { 5167dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::DictionaryValue* file = NULL; 5177dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch std::string path_string; 5187dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (!files->GetDictionary(i, &file) || 5197dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch !file->GetString("path", &path_string)) { 5207dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch NOTREACHED(); 5217dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch completion_callback.Run( 5227dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch NULL, SYNC_FILE_ERROR_FAILED, SYNC_FILE_STATUS_UNKNOWN); 5237dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch continue; 5247dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch } 5257dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 5267dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::FilePath file_path = base::FilePath::FromUTF8Unsafe(path_string); 5277dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch FileSystemURL url = CreateSyncableFileSystemURL(origin, file_path); 5287dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch GetFileSyncStatus(url, base::Bind(completion_callback, file)); 5297dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch } 5307dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch} 5317dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 532cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)void SyncFileSystemService::DidDumpDatabase( 533cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) const DumpFilesCallback& callback, scoped_ptr<base::ListValue> list) { 534cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) if (!list) 535cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) list = make_scoped_ptr(new base::ListValue); 536cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) 537cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) if (!v2_remote_service_) { 538cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) callback.Run(*list); 539cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) return; 540cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) } 541cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) 542cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) v2_remote_service_->DumpDatabase( 543cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) base::Bind(&SyncFileSystemService::DidDumpV2Database, 544cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) AsWeakPtr(), callback, base::Passed(&list))); 545cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)} 546cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) 547cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)void SyncFileSystemService::DidDumpV2Database( 548cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) const DumpFilesCallback& callback, 549cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) scoped_ptr<base::ListValue> v1list, 550cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) scoped_ptr<base::ListValue> v2list) { 551cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) DCHECK(v1list); 552cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) 553cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) if (v2list) { 554cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) for (base::ListValue::iterator itr = v2list->begin(); 555cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) itr != v2list->end();) { 556cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) scoped_ptr<base::Value> item; 557cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) itr = v2list->Erase(itr, &item); 558cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) v1list->Append(item.release()); 559cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) } 560cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) } 561cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) 562cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) callback.Run(*v1list); 563cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)} 564cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) 565cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)void SyncFileSystemService::DidGetExtensionStatusMap( 566cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) const ExtensionStatusMapCallback& callback, 567cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) scoped_ptr<RemoteFileSyncService::OriginStatusMap> status_map) { 568cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) if (!v2_remote_service_) { 569cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) callback.Run(*status_map); 570cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) return; 571cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) } 572cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) 573cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) v2_remote_service_->GetOriginStatusMap( 574cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) base::Bind(&SyncFileSystemService::DidGetV2ExtensionStatusMap, 575cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) AsWeakPtr(), 576cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) callback, 577cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) base::Passed(&status_map))); 578cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)} 579cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) 580cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)void SyncFileSystemService::DidGetV2ExtensionStatusMap( 581cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) const ExtensionStatusMapCallback& callback, 582cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) scoped_ptr<RemoteFileSyncService::OriginStatusMap> status_map_v1, 583cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) scoped_ptr<RemoteFileSyncService::OriginStatusMap> status_map_v2) { 584cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) // Merge |status_map_v2| into |status_map_v1|. 585cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) status_map_v1->insert(status_map_v2->begin(), status_map_v2->end()); 586cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) 587cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) callback.Run(*status_map_v1); 588cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)} 589cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) 5902a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::SetSyncEnabledForTesting(bool enabled) { 5912a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) sync_enabled_ = enabled; 592a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_->SetSyncEnabled(sync_enabled_); 593a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (v2_remote_service_) 594a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_->SetSyncEnabled(sync_enabled_); 5952a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 5962a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 5972a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::DidGetLocalChangeStatus( 5982a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const SyncFileStatusCallback& callback, 5992a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncStatusCode status, 6002a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool has_pending_local_changes) { 6012a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) callback.Run( 6022a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) status, 6032a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) has_pending_local_changes ? 6042a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SYNC_FILE_STATUS_HAS_PENDING_CHANGES : SYNC_FILE_STATUS_SYNCED); 6052a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 6062a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 6072a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::OnRemoteServiceStateUpdated( 6082a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) RemoteServiceState state, 6092a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const std::string& description) { 6102a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 6115d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) util::Log(logging::LOG_VERBOSE, FROM_HERE, 6127d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) "OnRemoteServiceStateChanged: %d %s", state, description.c_str()); 613c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 6142a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) FOR_EACH_OBSERVER( 6152a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncEventObserver, observers_, 6162a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) OnSyncStateUpdated(GURL(), 6172a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) RemoteStateToSyncServiceState(state), 6182a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) description)); 619a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 620a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) RunForEachSyncRunners(&SyncProcessRunner::Schedule); 6212a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 6222a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 623116680a4aac90f2aa7413d9095a592090648e557Ben Murdochvoid SyncFileSystemService::OnExtensionInstalled( 624116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch content::BrowserContext* browser_context, 625116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch const Extension* extension, 626116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch bool is_update) { 627d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) GURL app_origin = Extension::GetBaseURLFromExtensionId(extension->id()); 628c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) DVLOG(1) << "Handle extension notification for INSTALLED: " << app_origin; 629c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // NOTE: When an app is uninstalled and re-installed in a sequence, 630a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // |local_service_| may still keeps |app_origin| as disabled origin. 631a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->SetOriginEnabled(app_origin, true); 632c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles)} 633c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 634116680a4aac90f2aa7413d9095a592090648e557Ben Murdochvoid SyncFileSystemService::OnExtensionUnloaded( 635116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch content::BrowserContext* browser_context, 636116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch const Extension* extension, 637116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch extensions::UnloadedExtensionInfo::Reason reason) { 638116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch if (reason != extensions::UnloadedExtensionInfo::REASON_DISABLE) 639a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) return; 640d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 641116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch GURL app_origin = Extension::GetBaseURLFromExtensionId(extension->id()); 642116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch int disable_reasons = 643116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch ExtensionPrefs::Get(profile_)->GetDisableReasons(extension->id()); 644116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch if (disable_reasons & Extension::DISABLE_RELOAD) { 645d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // Bypass disabling the origin since the app will be re-enabled soon. 646d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // NOTE: If re-enabling the app fails, the app is disabled while it is 647d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // handled as enabled origin in the SyncFS. This should be safe and will be 648d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // recovered when the user re-enables the app manually or the sync service 649d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // restarts. 650d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) DVLOG(1) << "Handle extension notification for UNLOAD(DISABLE_RELOAD): " 651d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) << app_origin; 652d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) return; 653d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) } 654d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 655a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) DVLOG(1) << "Handle extension notification for UNLOAD(DISABLE): " 656a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) << app_origin; 657a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) GetRemoteService(app_origin)->DisableOrigin( 658a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) app_origin, 659116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch base::Bind(&DidHandleUnloadedEvent, app_origin)); 660a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->SetOriginEnabled(app_origin, false); 661a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles)} 6622a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 663116680a4aac90f2aa7413d9095a592090648e557Ben Murdochvoid SyncFileSystemService::OnExtensionUninstalled( 664116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch content::BrowserContext* browser_context, 6655f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) const Extension* extension, 6665f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) extensions::UninstallReason reason) { 66768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RemoteFileSyncService::UninstallFlag flag = 66868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RemoteFileSyncService::UNINSTALL_AND_PURGE_REMOTE; 66968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // If it's loaded from an unpacked package and with key: field, 67068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // the uninstall will not be sync'ed and the user might be using the 67168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // same app key in other installs, so avoid purging the remote folder. 67268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if (extensions::Manifest::IsUnpackedLocation(extension->location()) && 67368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) extension->manifest()->HasKey(extensions::manifest_keys::kKey)) { 67468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) flag = RemoteFileSyncService::UNINSTALL_AND_KEEP_REMOTE; 67568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) } 67668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 67768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) GURL app_origin = Extension::GetBaseURLFromExtensionId(extension->id()); 678a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) DVLOG(1) << "Handle extension notification for UNINSTALLED: " 679a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) << app_origin; 680a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) GetRemoteService(app_origin)->UninstallOrigin( 68168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) app_origin, flag, 682116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch base::Bind(&DidHandleUninstalledEvent, app_origin)); 683a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->SetOriginEnabled(app_origin, false); 6842a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 6852a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 686116680a4aac90f2aa7413d9095a592090648e557Ben Murdochvoid SyncFileSystemService::OnExtensionLoaded( 687116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch content::BrowserContext* browser_context, 688116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch const Extension* extension) { 689116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch GURL app_origin = Extension::GetBaseURLFromExtensionId(extension->id()); 690116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch DVLOG(1) << "Handle extension notification for LOADED: " << app_origin; 691a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) GetRemoteService(app_origin)->EnableOrigin( 6922a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) app_origin, 693116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch base::Bind(&DidHandleLoadEvent, app_origin)); 694a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->SetOriginEnabled(app_origin, true); 6952a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 6962a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 6972a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::OnStateChanged() { 6982a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceBase* profile_sync_service = 6992a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceFactory::GetForProfile(profile_); 7002a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (profile_sync_service) 7012a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) UpdateSyncEnabledStatus(profile_sync_service); 7022a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 7032a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 7042a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::OnFileStatusChanged( 7052a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const FileSystemURL& url, 7062a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncFileStatus sync_status, 7072a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncAction action_taken, 7082a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncDirection direction) { 7092a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) FOR_EACH_OBSERVER( 7102a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncEventObserver, observers_, 7112a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) OnFileSynced(url, sync_status, action_taken, direction)); 7122a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 7132a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 7142a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::UpdateSyncEnabledStatus( 7152a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceBase* profile_sync_service) { 7162a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (!profile_sync_service->HasSyncSetupCompleted()) 7172a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) return; 718d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) bool old_sync_enabled = sync_enabled_; 719868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) sync_enabled_ = profile_sync_service->GetActiveDataTypes().Has( 7202a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) syncer::APPS); 721a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_->SetSyncEnabled(sync_enabled_); 722a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (v2_remote_service_) 723a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_->SetSyncEnabled(sync_enabled_); 724a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (!old_sync_enabled && sync_enabled_) 725a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) RunForEachSyncRunners(&SyncProcessRunner::Schedule); 726a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)} 727a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 728a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)void SyncFileSystemService::RunForEachSyncRunners( 729a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) void(SyncProcessRunner::*method)()) { 7305d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) for (ScopedVector<SyncProcessRunner>::iterator iter = 7315d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) local_sync_runners_.begin(); 7325d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) iter != local_sync_runners_.end(); ++iter) 7335d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) ((*iter)->*method)(); 7345d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) for (ScopedVector<SyncProcessRunner>::iterator iter = 7355d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) remote_sync_runners_.begin(); 7365d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) iter != remote_sync_runners_.end(); ++iter) 737a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) ((*iter)->*method)(); 738a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)} 739a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 740a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)RemoteFileSyncService* SyncFileSystemService::GetRemoteService( 741a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const GURL& origin) { 742a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (IsV2Enabled()) 743a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return remote_service_.get(); 744a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (!IsV2EnabledForOrigin(origin)) 745a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return remote_service_.get(); 746a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 747a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (!v2_remote_service_) { 748a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_ = RemoteFileSyncService::CreateForBrowserContext( 749cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) RemoteFileSyncService::V2, profile_, &task_logger_); 750a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) scoped_ptr<RemoteSyncRunner> v2_remote_syncer( 751a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) new RemoteSyncRunner(kRemoteSyncNameV2, this, 752a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_.get())); 753a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_->AddServiceObserver(v2_remote_syncer.get()); 754a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_->AddFileStatusObserver(this); 755a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_->SetRemoteChangeProcessor(local_service_.get()); 756a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) v2_remote_service_->SetSyncEnabled(sync_enabled_); 7575d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) remote_sync_runners_.push_back(v2_remote_syncer.release()); 7582a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 759a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return v2_remote_service_.get(); 7605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace sync_file_system 763