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/non_blocking_invalidator.h" | 5 #include "sync/notifier/non_blocking_invalidator.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 123 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
134 } | 134 } |
135 | 135 |
136 NonBlockingInvalidator::NonBlockingInvalidator( | 136 NonBlockingInvalidator::NonBlockingInvalidator( |
137 const notifier::NotifierOptions& notifier_options, | 137 const notifier::NotifierOptions& notifier_options, |
138 const std::string& invalidator_client_id, | 138 const std::string& invalidator_client_id, |
139 const InvalidationStateMap& initial_invalidation_state_map, | 139 const InvalidationStateMap& initial_invalidation_state_map, |
140 const std::string& invalidation_bootstrap_data, | 140 const std::string& invalidation_bootstrap_data, |
141 const WeakHandle<InvalidationStateTracker>& | 141 const WeakHandle<InvalidationStateTracker>& |
142 invalidation_state_tracker, | 142 invalidation_state_tracker, |
143 const std::string& client_info) | 143 const std::string& client_info) |
144 : weak_ptr_factory_(this), | 144 : parent_task_runner_(base::ThreadTaskRunnerHandle::Get()), |
145 core_( | 145 network_task_runner_(notifier_options.request_context_getter-> |
akalin
2013/10/08 22:26:04
break after (?
dmichael (off chromium)
2013/10/08 22:41:19
Done.
| |
146 new Core(MakeWeakHandle(weak_ptr_factory_.GetWeakPtr()))), | 146 GetNetworkTaskRunner()), |
147 parent_task_runner_( | 147 weak_ptr_factory_(this) { |
148 base::ThreadTaskRunnerHandle::Get()), | 148 core_ = new Core(MakeWeakHandle(weak_ptr_factory_.GetWeakPtr())); |
149 network_task_runner_(notifier_options.request_context_getter-> | 149 |
150 GetNetworkTaskRunner()) { | |
151 if (!network_task_runner_->PostTask( | 150 if (!network_task_runner_->PostTask( |
152 FROM_HERE, | 151 FROM_HERE, |
153 base::Bind( | 152 base::Bind( |
154 &NonBlockingInvalidator::Core::Initialize, | 153 &NonBlockingInvalidator::Core::Initialize, |
155 core_.get(), | 154 core_.get(), |
156 notifier_options, | 155 notifier_options, |
157 invalidator_client_id, | 156 invalidator_client_id, |
158 initial_invalidation_state_map, | 157 initial_invalidation_state_map, |
159 invalidation_bootstrap_data, | 158 invalidation_bootstrap_data, |
160 invalidation_state_tracker, | 159 invalidation_state_tracker, |
(...skipping 71 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
232 registrar_.UpdateInvalidatorState(state); | 231 registrar_.UpdateInvalidatorState(state); |
233 } | 232 } |
234 | 233 |
235 void NonBlockingInvalidator::OnIncomingInvalidation( | 234 void NonBlockingInvalidator::OnIncomingInvalidation( |
236 const ObjectIdInvalidationMap& invalidation_map) { | 235 const ObjectIdInvalidationMap& invalidation_map) { |
237 DCHECK(parent_task_runner_->BelongsToCurrentThread()); | 236 DCHECK(parent_task_runner_->BelongsToCurrentThread()); |
238 registrar_.DispatchInvalidationsToHandlers(invalidation_map); | 237 registrar_.DispatchInvalidationsToHandlers(invalidation_map); |
239 } | 238 } |
240 | 239 |
241 } // namespace syncer | 240 } // namespace syncer |
OLD | NEW |