| OLD | NEW |
| 1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "build/build_config.h" | 5 #include "build/build_config.h" |
| 6 #include "base/file_util.h" | 6 #include "base/file_util.h" |
| 7 #include "base/file_version_info.h" | 7 #include "base/file_version_info.h" |
| 8 #include "base/task.h" | 8 #include "base/task.h" |
| 9 #include "base/utf_string_conversions.h" | 9 #include "base/utf_string_conversions.h" |
| 10 #include "chrome/app/chrome_version_info.h" | 10 #include "chrome/app/chrome_version_info.h" |
| 11 #include "chrome/browser/chrome_thread.h" | 11 #include "chrome/browser/chrome_thread.h" |
| (...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 60 } | 60 } |
| 61 | 61 |
| 62 SyncBackendHost::~SyncBackendHost() { | 62 SyncBackendHost::~SyncBackendHost() { |
| 63 DCHECK(!core_ && !frontend_) << "Must call Shutdown before destructor."; | 63 DCHECK(!core_ && !frontend_) << "Must call Shutdown before destructor."; |
| 64 DCHECK(registrar_.workers.empty()); | 64 DCHECK(registrar_.workers.empty()); |
| 65 } | 65 } |
| 66 | 66 |
| 67 void SyncBackendHost::Initialize( | 67 void SyncBackendHost::Initialize( |
| 68 const GURL& sync_service_url, | 68 const GURL& sync_service_url, |
| 69 const syncable::ModelTypeSet& types, | 69 const syncable::ModelTypeSet& types, |
| 70 chrome_common_net::NetworkChangeNotifierThread* | |
| 71 network_change_notifier_thread, | |
| 72 URLRequestContextGetter* baseline_context_getter, | 70 URLRequestContextGetter* baseline_context_getter, |
| 73 const std::string& lsid, | 71 const std::string& lsid, |
| 74 bool delete_sync_data_folder, | 72 bool delete_sync_data_folder, |
| 75 bool invalidate_sync_login, | 73 bool invalidate_sync_login, |
| 76 bool invalidate_sync_xmpp_login, | 74 bool invalidate_sync_xmpp_login, |
| 77 NotificationMethod notification_method) { | 75 NotificationMethod notification_method) { |
| 78 if (!core_thread_.Start()) | 76 if (!core_thread_.Start()) |
| 79 return; | 77 return; |
| 80 | 78 |
| 81 // Create a worker for the UI thread and route bookmark changes to it. | 79 // Create a worker for the UI thread and route bookmark changes to it. |
| (...skipping 18 matching lines...) Expand all Loading... |
| 100 for (syncable::ModelTypeSet::const_iterator it = types.begin(); | 98 for (syncable::ModelTypeSet::const_iterator it = types.begin(); |
| 101 it != types.end(); ++it) { | 99 it != types.end(); ++it) { |
| 102 registrar_.routing_info[(*it)] = GROUP_PASSIVE; | 100 registrar_.routing_info[(*it)] = GROUP_PASSIVE; |
| 103 } | 101 } |
| 104 registrar_.routing_info[syncable::NIGORI] = GROUP_PASSIVE; | 102 registrar_.routing_info[syncable::NIGORI] = GROUP_PASSIVE; |
| 105 | 103 |
| 106 core_thread_.message_loop()->PostTask(FROM_HERE, | 104 core_thread_.message_loop()->PostTask(FROM_HERE, |
| 107 NewRunnableMethod(core_.get(), &SyncBackendHost::Core::DoInitialize, | 105 NewRunnableMethod(core_.get(), &SyncBackendHost::Core::DoInitialize, |
| 108 Core::DoInitializeOptions( | 106 Core::DoInitializeOptions( |
| 109 sync_service_url, true, | 107 sync_service_url, true, |
| 110 network_change_notifier_thread, | |
| 111 new HttpBridgeFactory(baseline_context_getter), | 108 new HttpBridgeFactory(baseline_context_getter), |
| 112 new HttpBridgeFactory(baseline_context_getter), | 109 new HttpBridgeFactory(baseline_context_getter), |
| 113 lsid, | 110 lsid, |
| 114 delete_sync_data_folder, | 111 delete_sync_data_folder, |
| 115 invalidate_sync_login, | 112 invalidate_sync_login, |
| 116 invalidate_sync_xmpp_login, | 113 invalidate_sync_xmpp_login, |
| 117 notification_method))); | 114 notification_method))); |
| 118 } | 115 } |
| 119 | 116 |
| 120 void SyncBackendHost::Authenticate(const std::string& username, | 117 void SyncBackendHost::Authenticate(const std::string& username, |
| (...skipping 264 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 385 DCHECK(success); | 382 DCHECK(success); |
| 386 | 383 |
| 387 syncapi_->SetObserver(this); | 384 syncapi_->SetObserver(this); |
| 388 const FilePath& path_str = host_->sync_data_folder_path(); | 385 const FilePath& path_str = host_->sync_data_folder_path(); |
| 389 success = syncapi_->Init(path_str, | 386 success = syncapi_->Init(path_str, |
| 390 (options.service_url.host() + options.service_url.path()).c_str(), | 387 (options.service_url.host() + options.service_url.path()).c_str(), |
| 391 options.service_url.EffectiveIntPort(), | 388 options.service_url.EffectiveIntPort(), |
| 392 kGaiaServiceId, | 389 kGaiaServiceId, |
| 393 kGaiaSourceForChrome, | 390 kGaiaSourceForChrome, |
| 394 options.service_url.SchemeIsSecure(), | 391 options.service_url.SchemeIsSecure(), |
| 395 options.network_change_notifier_thread, | |
| 396 options.http_bridge_factory, | 392 options.http_bridge_factory, |
| 397 options.auth_http_bridge_factory, | 393 options.auth_http_bridge_factory, |
| 398 host_, // ModelSafeWorkerRegistrar. | 394 host_, // ModelSafeWorkerRegistrar. |
| 399 options.attempt_last_user_authentication, | 395 options.attempt_last_user_authentication, |
| 400 options.invalidate_sync_login, | 396 options.invalidate_sync_login, |
| 401 options.invalidate_sync_xmpp_login, | 397 options.invalidate_sync_xmpp_login, |
| 402 MakeUserAgentForSyncapi().c_str(), | 398 MakeUserAgentForSyncapi().c_str(), |
| 403 options.lsid.c_str(), | 399 options.lsid.c_str(), |
| 404 options.notification_method); | 400 options.notification_method); |
| 405 DCHECK(success) << "Syncapi initialization failed!"; | 401 DCHECK(success) << "Syncapi initialization failed!"; |
| (...skipping 203 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 609 } | 605 } |
| 610 | 606 |
| 611 void SyncBackendHost::Core::DeleteSyncDataFolder() { | 607 void SyncBackendHost::Core::DeleteSyncDataFolder() { |
| 612 if (file_util::DirectoryExists(host_->sync_data_folder_path())) { | 608 if (file_util::DirectoryExists(host_->sync_data_folder_path())) { |
| 613 if (!file_util::Delete(host_->sync_data_folder_path(), true)) | 609 if (!file_util::Delete(host_->sync_data_folder_path(), true)) |
| 614 LOG(DFATAL) << "Could not delete the Sync Data folder."; | 610 LOG(DFATAL) << "Could not delete the Sync Data folder."; |
| 615 } | 611 } |
| 616 } | 612 } |
| 617 | 613 |
| 618 } // namespace browser_sync | 614 } // namespace browser_sync |
| OLD | NEW |