| Index: sync/notifier/non_blocking_invalidator.cc
|
| diff --git a/sync/notifier/non_blocking_invalidator.cc b/sync/notifier/non_blocking_invalidator.cc
|
| index 5ff8dfa0a9cb015fde82bb23d2ca904f813393d7..b736c9cf8c46984f005f7b4fd336b01409adbbbc 100644
|
| --- a/sync/notifier/non_blocking_invalidator.cc
|
| +++ b/sync/notifier/non_blocking_invalidator.cc
|
| @@ -30,13 +30,13 @@ class NonBlockingInvalidator::Core
|
| // Helpers called on I/O thread.
|
| void Initialize(
|
| const notifier::NotifierOptions& notifier_options,
|
| + const std::string& invalidator_client_id,
|
| const InvalidationStateMap& initial_invalidation_state_map,
|
| const std::string& invalidation_bootstrap_data,
|
| const WeakHandle<InvalidationStateTracker>& invalidation_state_tracker,
|
| const std::string& client_info);
|
| void Teardown();
|
| void UpdateRegisteredIds(const ObjectIdSet& ids);
|
| - void SetUniqueId(const std::string& unique_id);
|
| void UpdateCredentials(const std::string& email, const std::string& token);
|
|
|
| // InvalidationHandler implementation (all called on I/O thread by
|
| @@ -71,6 +71,7 @@ NonBlockingInvalidator::Core::~Core() {
|
|
|
| void NonBlockingInvalidator::Core::Initialize(
|
| const notifier::NotifierOptions& notifier_options,
|
| + const std::string& invalidator_client_id,
|
| const InvalidationStateMap& initial_invalidation_state_map,
|
| const std::string& invalidation_bootstrap_data,
|
| const WeakHandle<InvalidationStateTracker>& invalidation_state_tracker,
|
| @@ -84,6 +85,7 @@ void NonBlockingInvalidator::Core::Initialize(
|
| invalidation_notifier_.reset(
|
| new InvalidationNotifier(
|
| notifier::PushClient::CreateDefaultOnIOThread(notifier_options),
|
| + invalidator_client_id,
|
| initial_invalidation_state_map,
|
| invalidation_bootstrap_data,
|
| invalidation_state_tracker,
|
| @@ -103,11 +105,6 @@ void NonBlockingInvalidator::Core::UpdateRegisteredIds(const ObjectIdSet& ids) {
|
| invalidation_notifier_->UpdateRegisteredIds(this, ids);
|
| }
|
|
|
| -void NonBlockingInvalidator::Core::SetUniqueId(const std::string& unique_id) {
|
| - DCHECK(network_task_runner_->BelongsToCurrentThread());
|
| - invalidation_notifier_->SetUniqueId(unique_id);
|
| -}
|
| -
|
| void NonBlockingInvalidator::Core::UpdateCredentials(const std::string& email,
|
| const std::string& token) {
|
| DCHECK(network_task_runner_->BelongsToCurrentThread());
|
| @@ -133,6 +130,7 @@ void NonBlockingInvalidator::Core::OnIncomingInvalidation(
|
|
|
| NonBlockingInvalidator::NonBlockingInvalidator(
|
| const notifier::NotifierOptions& notifier_options,
|
| + const std::string& invalidator_client_id,
|
| const InvalidationStateMap& initial_max_invalidation_versions,
|
| const std::string& invalidation_bootstrap_data,
|
| const WeakHandle<InvalidationStateTracker>&
|
| @@ -144,13 +142,15 @@ NonBlockingInvalidator::NonBlockingInvalidator(
|
| parent_task_runner_(
|
| base::ThreadTaskRunnerHandle::Get()),
|
| network_task_runner_(notifier_options.request_context_getter->
|
| - GetNetworkTaskRunner()) {
|
| + GetNetworkTaskRunner()),
|
| + invalidator_client_id_(invalidator_client_id) {
|
| if (!network_task_runner_->PostTask(
|
| FROM_HERE,
|
| base::Bind(
|
| &NonBlockingInvalidator::Core::Initialize,
|
| core_.get(),
|
| notifier_options,
|
| + invalidator_client_id_,
|
| initial_max_invalidation_versions,
|
| invalidation_bootstrap_data,
|
| invalidation_state_tracker,
|
| @@ -198,16 +198,6 @@ InvalidatorState NonBlockingInvalidator::GetInvalidatorState() const {
|
| return registrar_.GetInvalidatorState();
|
| }
|
|
|
| -void NonBlockingInvalidator::SetUniqueId(const std::string& unique_id) {
|
| - DCHECK(parent_task_runner_->BelongsToCurrentThread());
|
| - if (!network_task_runner_->PostTask(
|
| - FROM_HERE,
|
| - base::Bind(&NonBlockingInvalidator::Core::SetUniqueId,
|
| - core_.get(), unique_id))) {
|
| - NOTREACHED();
|
| - }
|
| -}
|
| -
|
| void NonBlockingInvalidator::UpdateCredentials(const std::string& email,
|
| const std::string& token) {
|
| DCHECK(parent_task_runner_->BelongsToCurrentThread());
|
|
|