OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "components/invalidation/non_blocking_invalidator.h" | 5 #include "components/invalidation/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 125 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
136 DISALLOW_COPY_AND_ASSIGN(Core); | 136 DISALLOW_COPY_AND_ASSIGN(Core); |
137 }; | 137 }; |
138 | 138 |
139 NonBlockingInvalidator::Core::Core( | 139 NonBlockingInvalidator::Core::Core( |
140 const base::WeakPtr<NonBlockingInvalidator>& delegate_observer, | 140 const base::WeakPtr<NonBlockingInvalidator>& delegate_observer, |
141 const scoped_refptr<base::SingleThreadTaskRunner>& | 141 const scoped_refptr<base::SingleThreadTaskRunner>& |
142 delegate_observer_task_runner) | 142 delegate_observer_task_runner) |
143 : delegate_observer_(delegate_observer), | 143 : delegate_observer_(delegate_observer), |
144 delegate_observer_task_runner_(delegate_observer_task_runner) { | 144 delegate_observer_task_runner_(delegate_observer_task_runner) { |
145 DCHECK(delegate_observer_); | 145 DCHECK(delegate_observer_); |
146 DCHECK(delegate_observer_task_runner_); | 146 DCHECK(delegate_observer_task_runner_.get()); |
147 } | 147 } |
148 | 148 |
149 NonBlockingInvalidator::Core::~Core() { | 149 NonBlockingInvalidator::Core::~Core() { |
150 } | 150 } |
151 | 151 |
152 void NonBlockingInvalidator::Core::Initialize( | 152 void NonBlockingInvalidator::Core::Initialize( |
153 const NonBlockingInvalidator::InitializeOptions& initialize_options) { | 153 const NonBlockingInvalidator::InitializeOptions& initialize_options) { |
154 DCHECK(initialize_options.request_context_getter.get()); | 154 DCHECK(initialize_options.request_context_getter.get()); |
155 network_task_runner_ = | 155 network_task_runner_ = |
156 initialize_options.request_context_getter->GetNetworkTaskRunner(); | 156 initialize_options.request_context_getter->GetNetworkTaskRunner(); |
(...skipping 219 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
376 | 376 |
377 void NonBlockingInvalidator::OnIncomingInvalidation( | 377 void NonBlockingInvalidator::OnIncomingInvalidation( |
378 const ObjectIdInvalidationMap& invalidation_map) { | 378 const ObjectIdInvalidationMap& invalidation_map) { |
379 DCHECK(parent_task_runner_->BelongsToCurrentThread()); | 379 DCHECK(parent_task_runner_->BelongsToCurrentThread()); |
380 registrar_.DispatchInvalidationsToHandlers(invalidation_map); | 380 registrar_.DispatchInvalidationsToHandlers(invalidation_map); |
381 } | 381 } |
382 | 382 |
383 std::string NonBlockingInvalidator::GetOwnerName() const { return "Sync"; } | 383 std::string NonBlockingInvalidator::GetOwnerName() const { return "Sync"; } |
384 | 384 |
385 } // namespace syncer | 385 } // namespace syncer |
OLD | NEW |