OLD | NEW |
1 // Copyright (c) 2010 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 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 | 8 |
9 #include "base/compiler_specific.h" | 9 #include "base/compiler_specific.h" |
10 #include "base/command_line.h" | 10 #include "base/command_line.h" |
(...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
104 | 104 |
105 if (CommandLine::ForCurrentProcess()->HasSwitch( | 105 if (CommandLine::ForCurrentProcess()->HasSwitch( |
106 switches::kEnableSyncTypedUrls) || types.count(syncable::TYPED_URLS)) { | 106 switches::kEnableSyncTypedUrls) || types.count(syncable::TYPED_URLS)) { |
107 // TODO(tim): Bug 53916. HistoryModelWorker crashes, so avoid adding it | 107 // TODO(tim): Bug 53916. HistoryModelWorker crashes, so avoid adding it |
108 // unless specifically requested until bug is fixed. | 108 // unless specifically requested until bug is fixed. |
109 registrar_.workers[GROUP_HISTORY] = | 109 registrar_.workers[GROUP_HISTORY] = |
110 new HistoryModelWorker( | 110 new HistoryModelWorker( |
111 profile_->GetHistoryService(Profile::IMPLICIT_ACCESS)); | 111 profile_->GetHistoryService(Profile::IMPLICIT_ACCESS)); |
112 } | 112 } |
113 | 113 |
| 114 // Any datatypes that we want the syncer to pull down must |
| 115 // be in the routing_info map. We set them to group passive, meaning that |
| 116 // updates will be applied, but not dispatched to the UI thread yet. |
| 117 for (syncable::ModelTypeSet::const_iterator it = types.begin(); |
| 118 it != types.end(); ++it) { |
| 119 registrar_.routing_info[(*it)] = GROUP_PASSIVE; |
| 120 } |
| 121 |
114 PasswordStore* password_store = | 122 PasswordStore* password_store = |
115 profile_->GetPasswordStore(Profile::IMPLICIT_ACCESS); | 123 profile_->GetPasswordStore(Profile::IMPLICIT_ACCESS); |
116 if (password_store) { | 124 if (password_store) { |
117 registrar_.workers[GROUP_PASSWORD] = | 125 registrar_.workers[GROUP_PASSWORD] = |
118 new PasswordModelWorker(password_store); | 126 new PasswordModelWorker(password_store); |
119 } else { | 127 } else { |
120 LOG(WARNING) << "Password store not initialized, cannot sync passwords"; | 128 LOG(WARNING) << "Password store not initialized, cannot sync passwords"; |
121 } | 129 registrar_.routing_info.erase(syncable::PASSWORDS); |
122 | |
123 // Any datatypes that we want the syncer to pull down must | |
124 // be in the routing_info map. We set them to group passive, meaning that | |
125 // updates will be applied, but not dispatched to the UI thread yet. | |
126 for (syncable::ModelTypeSet::const_iterator it = types.begin(); | |
127 it != types.end(); ++it) { | |
128 registrar_.routing_info[(*it)] = GROUP_PASSIVE; | |
129 } | 130 } |
130 | 131 |
131 // TODO(tim): Remove this special case once NIGORI is populated by | 132 // TODO(tim): Remove this special case once NIGORI is populated by |
132 // default. We piggy back off of the passwords flag for now to not | 133 // default. We piggy back off of the passwords flag for now to not |
133 // require both encryption and passwords flags. | 134 // require both encryption and passwords flags. |
134 bool enable_encryption = !CommandLine::ForCurrentProcess()->HasSwitch( | 135 bool enable_encryption = !CommandLine::ForCurrentProcess()->HasSwitch( |
135 switches::kDisableSyncPasswords) || types.count(syncable::PASSWORDS); | 136 switches::kDisableSyncPasswords) || types.count(syncable::PASSWORDS); |
136 if (enable_encryption) | 137 if (enable_encryption) |
137 registrar_.routing_info[syncable::NIGORI] = GROUP_PASSIVE; | 138 registrar_.routing_info[syncable::NIGORI] = GROUP_PASSIVE; |
138 | 139 |
(...skipping 865 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1004 } | 1005 } |
1005 | 1006 |
1006 void SyncBackendHost::Core::DoProcessMessage( | 1007 void SyncBackendHost::Core::DoProcessMessage( |
1007 const std::string& name, const JsArgList& args, | 1008 const std::string& name, const JsArgList& args, |
1008 const JsEventHandler* sender) { | 1009 const JsEventHandler* sender) { |
1009 DCHECK_EQ(MessageLoop::current(), host_->core_thread_.message_loop()); | 1010 DCHECK_EQ(MessageLoop::current(), host_->core_thread_.message_loop()); |
1010 syncapi_->GetJsBackend()->ProcessMessage(name, args, sender); | 1011 syncapi_->GetJsBackend()->ProcessMessage(name, args, sender); |
1011 } | 1012 } |
1012 | 1013 |
1013 } // namespace browser_sync | 1014 } // namespace browser_sync |
OLD | NEW |