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()); |