OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "sync/notifier/invalidation_notifier.h" | 5 #include "sync/notifier/invalidation_notifier.h" |
6 | 6 |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 #include "base/message_loop_proxy.h" | 8 #include "base/message_loop_proxy.h" |
9 #include "jingle/notifier/base/const_communicator.h" | 9 #include "jingle/notifier/base/const_communicator.h" |
10 #include "jingle/notifier/base/notifier_options_util.h" | 10 #include "jingle/notifier/base/notifier_options_util.h" |
11 #include "net/url_request/url_request_context.h" | 11 #include "net/url_request/url_request_context.h" |
12 #include "sync/notifier/sync_notifier_observer.h" | 12 #include "sync/notifier/sync_notifier_observer.h" |
13 #include "sync/protocol/service_constants.h" | |
14 #include "sync/syncable/model_type_payload_map.h" | 13 #include "sync/syncable/model_type_payload_map.h" |
15 #include "talk/xmpp/jid.h" | 14 #include "talk/xmpp/jid.h" |
16 #include "talk/xmpp/xmppclientsettings.h" | 15 #include "talk/xmpp/xmppclientsettings.h" |
17 | 16 |
18 namespace sync_notifier { | 17 namespace sync_notifier { |
19 | 18 |
20 InvalidationNotifier::InvalidationNotifier( | 19 InvalidationNotifier::InvalidationNotifier( |
21 const notifier::NotifierOptions& notifier_options, | 20 const notifier::NotifierOptions& notifier_options, |
22 const InvalidationVersionMap& initial_max_invalidation_versions, | 21 const InvalidationVersionMap& initial_max_invalidation_versions, |
23 const browser_sync::WeakHandle<InvalidationVersionTracker>& | 22 const browser_sync::WeakHandle<InvalidationVersionTracker>& |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
62 invalidation_state_ = state; | 61 invalidation_state_ = state; |
63 DVLOG(1) << "Setting new state"; | 62 DVLOG(1) << "Setting new state"; |
64 } | 63 } |
65 | 64 |
66 void InvalidationNotifier::UpdateCredentials( | 65 void InvalidationNotifier::UpdateCredentials( |
67 const std::string& email, const std::string& token) { | 66 const std::string& email, const std::string& token) { |
68 DCHECK(non_thread_safe_.CalledOnValidThread()); | 67 DCHECK(non_thread_safe_.CalledOnValidThread()); |
69 CHECK(!invalidation_client_id_.empty()); | 68 CHECK(!invalidation_client_id_.empty()); |
70 DVLOG(1) << "Updating credentials for " << email; | 69 DVLOG(1) << "Updating credentials for " << email; |
71 buzz::XmppClientSettings xmpp_client_settings = | 70 buzz::XmppClientSettings xmpp_client_settings = |
72 notifier::MakeXmppClientSettings(notifier_options_, | 71 notifier::MakeXmppClientSettings(notifier_options_, email, token); |
73 email, token, SYNC_SERVICE_NAME); | |
74 if (state_ >= CONNECTING) { | 72 if (state_ >= CONNECTING) { |
75 login_->UpdateXmppSettings(xmpp_client_settings); | 73 login_->UpdateXmppSettings(xmpp_client_settings); |
76 } else { | 74 } else { |
77 DVLOG(1) << "First time updating credentials: connecting"; | 75 DVLOG(1) << "First time updating credentials: connecting"; |
78 login_.reset( | 76 login_.reset( |
79 new notifier::Login(this, | 77 new notifier::Login(this, |
80 xmpp_client_settings, | 78 xmpp_client_settings, |
81 notifier_options_.request_context_getter, | 79 notifier_options_.request_context_getter, |
82 notifier::GetServerList(notifier_options_), | 80 notifier::GetServerList(notifier_options_), |
83 notifier_options_.try_ssltcp_first, | 81 notifier_options_.try_ssltcp_first, |
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
138 OnNotificationStateChange(has_session)); | 136 OnNotificationStateChange(has_session)); |
139 } | 137 } |
140 | 138 |
141 void InvalidationNotifier::WriteState(const std::string& state) { | 139 void InvalidationNotifier::WriteState(const std::string& state) { |
142 DCHECK(non_thread_safe_.CalledOnValidThread()); | 140 DCHECK(non_thread_safe_.CalledOnValidThread()); |
143 DVLOG(1) << "WriteState"; | 141 DVLOG(1) << "WriteState"; |
144 FOR_EACH_OBSERVER(SyncNotifierObserver, observers_, StoreState(state)); | 142 FOR_EACH_OBSERVER(SyncNotifierObserver, observers_, StoreState(state)); |
145 } | 143 } |
146 | 144 |
147 } // namespace sync_notifier | 145 } // namespace sync_notifier |
OLD | NEW |