Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(54)

Side by Side Diff: sync/notifier/non_blocking_invalidation_notifier.cc

Issue 10837214: Refactor ModelTypePayloadMap and ObjectIdPayloadMap to StateMaps. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Fix unit test Created 8 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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/non_blocking_invalidation_notifier.h" 5 #include "sync/notifier/non_blocking_invalidation_notifier.h"
6 6
7 #include <cstddef> 7 #include <cstddef>
8 8
9 #include "base/location.h" 9 #include "base/location.h"
10 #include "base/logging.h" 10 #include "base/logging.h"
(...skipping 28 matching lines...) Expand all
39 void SetUniqueId(const std::string& unique_id); 39 void SetUniqueId(const std::string& unique_id);
40 void SetStateDeprecated(const std::string& state); 40 void SetStateDeprecated(const std::string& state);
41 void UpdateCredentials(const std::string& email, const std::string& token); 41 void UpdateCredentials(const std::string& email, const std::string& token);
42 42
43 // SyncNotifierObserver implementation (all called on I/O thread by 43 // SyncNotifierObserver implementation (all called on I/O thread by
44 // InvalidationNotifier). 44 // InvalidationNotifier).
45 virtual void OnNotificationsEnabled() OVERRIDE; 45 virtual void OnNotificationsEnabled() OVERRIDE;
46 virtual void OnNotificationsDisabled( 46 virtual void OnNotificationsDisabled(
47 NotificationsDisabledReason reason) OVERRIDE; 47 NotificationsDisabledReason reason) OVERRIDE;
48 virtual void OnIncomingNotification( 48 virtual void OnIncomingNotification(
49 const ObjectIdPayloadMap& id_payloads, 49 const ObjectIdStateMap& id_state_map,
50 IncomingNotificationSource source) OVERRIDE; 50 IncomingNotificationSource source) OVERRIDE;
51 51
52 private: 52 private:
53 friend class 53 friend class
54 base::RefCountedThreadSafe<NonBlockingInvalidationNotifier::Core>; 54 base::RefCountedThreadSafe<NonBlockingInvalidationNotifier::Core>;
55 // Called on parent or I/O thread. 55 // Called on parent or I/O thread.
56 ~Core(); 56 ~Core();
57 57
58 // The variables below should be used only on the I/O thread. 58 // The variables below should be used only on the I/O thread.
59 const WeakHandle<SyncNotifierObserver> delegate_observer_; 59 const WeakHandle<SyncNotifierObserver> delegate_observer_;
(...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after
132 } 132 }
133 133
134 void NonBlockingInvalidationNotifier::Core::OnNotificationsDisabled( 134 void NonBlockingInvalidationNotifier::Core::OnNotificationsDisabled(
135 NotificationsDisabledReason reason) { 135 NotificationsDisabledReason reason) {
136 DCHECK(network_task_runner_->BelongsToCurrentThread()); 136 DCHECK(network_task_runner_->BelongsToCurrentThread());
137 delegate_observer_.Call( 137 delegate_observer_.Call(
138 FROM_HERE, &SyncNotifierObserver::OnNotificationsDisabled, reason); 138 FROM_HERE, &SyncNotifierObserver::OnNotificationsDisabled, reason);
139 } 139 }
140 140
141 void NonBlockingInvalidationNotifier::Core::OnIncomingNotification( 141 void NonBlockingInvalidationNotifier::Core::OnIncomingNotification(
142 const ObjectIdPayloadMap& id_payloads, IncomingNotificationSource source) { 142 const ObjectIdStateMap& id_state_map, IncomingNotificationSource source) {
143 DCHECK(network_task_runner_->BelongsToCurrentThread()); 143 DCHECK(network_task_runner_->BelongsToCurrentThread());
144 delegate_observer_.Call(FROM_HERE, 144 delegate_observer_.Call(FROM_HERE,
145 &SyncNotifierObserver::OnIncomingNotification, 145 &SyncNotifierObserver::OnIncomingNotification,
146 id_payloads, 146 id_state_map,
147 source); 147 source);
148 } 148 }
149 149
150 NonBlockingInvalidationNotifier::NonBlockingInvalidationNotifier( 150 NonBlockingInvalidationNotifier::NonBlockingInvalidationNotifier(
151 const notifier::NotifierOptions& notifier_options, 151 const notifier::NotifierOptions& notifier_options,
152 const InvalidationVersionMap& initial_max_invalidation_versions, 152 const InvalidationVersionMap& initial_max_invalidation_versions,
153 const std::string& initial_invalidation_state, 153 const std::string& initial_invalidation_state,
154 const WeakHandle<InvalidationStateTracker>& 154 const WeakHandle<InvalidationStateTracker>&
155 invalidation_state_tracker, 155 invalidation_state_tracker,
156 const std::string& client_info) 156 const std::string& client_info)
(...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after
258 registrar_.EmitOnNotificationsEnabled(); 258 registrar_.EmitOnNotificationsEnabled();
259 } 259 }
260 260
261 void NonBlockingInvalidationNotifier::OnNotificationsDisabled( 261 void NonBlockingInvalidationNotifier::OnNotificationsDisabled(
262 NotificationsDisabledReason reason) { 262 NotificationsDisabledReason reason) {
263 DCHECK(parent_task_runner_->BelongsToCurrentThread()); 263 DCHECK(parent_task_runner_->BelongsToCurrentThread());
264 registrar_.EmitOnNotificationsDisabled(reason); 264 registrar_.EmitOnNotificationsDisabled(reason);
265 } 265 }
266 266
267 void NonBlockingInvalidationNotifier::OnIncomingNotification( 267 void NonBlockingInvalidationNotifier::OnIncomingNotification(
268 const ObjectIdPayloadMap& id_payloads, 268 const ObjectIdStateMap& id_state_map,
269 IncomingNotificationSource source) { 269 IncomingNotificationSource source) {
270 DCHECK(parent_task_runner_->BelongsToCurrentThread()); 270 DCHECK(parent_task_runner_->BelongsToCurrentThread());
271 registrar_.DispatchInvalidationsToHandlers(id_payloads, source); 271 registrar_.DispatchInvalidationsToHandlers(id_state_map, source);
272 } 272 }
273 273
274 } // namespace syncer 274 } // namespace syncer
OLDNEW
« no previous file with comments | « sync/notifier/non_blocking_invalidation_notifier.h ('k') | sync/notifier/non_blocking_invalidation_notifier_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698