| 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 |