| Index: sync/notifier/non_blocking_invalidator.cc
|
| diff --git a/sync/notifier/non_blocking_invalidation_notifier.cc b/sync/notifier/non_blocking_invalidator.cc
|
| similarity index 69%
|
| rename from sync/notifier/non_blocking_invalidation_notifier.cc
|
| rename to sync/notifier/non_blocking_invalidator.cc
|
| index 89fb19a3432fe6490363f4d7b3f415e1a6bcc765..ab4f1663723dc6d10a27ca6e861fd2a21f8fa81e 100644
|
| --- a/sync/notifier/non_blocking_invalidation_notifier.cc
|
| +++ b/sync/notifier/non_blocking_invalidator.cc
|
| @@ -2,7 +2,7 @@
|
| // Use of this source code is governed by a BSD-style license that can be
|
| // found in the LICENSE file.
|
|
|
| -#include "sync/notifier/non_blocking_invalidation_notifier.h"
|
| +#include "sync/notifier/non_blocking_invalidator.h"
|
|
|
| #include <cstddef>
|
|
|
| @@ -17,15 +17,15 @@
|
|
|
| namespace syncer {
|
|
|
| -class NonBlockingInvalidationNotifier::Core
|
| - : public base::RefCountedThreadSafe<NonBlockingInvalidationNotifier::Core>,
|
| - // SyncNotifierObserver to observe the InvalidationNotifier we create.
|
| - public SyncNotifierObserver {
|
| +class NonBlockingInvalidator::Core
|
| + : public base::RefCountedThreadSafe<NonBlockingInvalidator::Core>,
|
| + // InvalidationHandler to observe the InvalidationNotifier we create.
|
| + public InvalidationHandler {
|
| public:
|
| // Called on parent thread. |delegate_observer| should be
|
| // initialized.
|
| explicit Core(
|
| - const WeakHandle<SyncNotifierObserver>& delegate_observer);
|
| + const WeakHandle<InvalidationHandler>& delegate_observer);
|
|
|
| // Helpers called on I/O thread.
|
| void Initialize(
|
| @@ -40,7 +40,7 @@ class NonBlockingInvalidationNotifier::Core
|
| void SetStateDeprecated(const std::string& state);
|
| void UpdateCredentials(const std::string& email, const std::string& token);
|
|
|
| - // SyncNotifierObserver implementation (all called on I/O thread by
|
| + // InvalidationHandler implementation (all called on I/O thread by
|
| // InvalidationNotifier).
|
| virtual void OnNotificationsEnabled() OVERRIDE;
|
| virtual void OnNotificationsDisabled(
|
| @@ -51,28 +51,28 @@ class NonBlockingInvalidationNotifier::Core
|
|
|
| private:
|
| friend class
|
| - base::RefCountedThreadSafe<NonBlockingInvalidationNotifier::Core>;
|
| + base::RefCountedThreadSafe<NonBlockingInvalidator::Core>;
|
| // Called on parent or I/O thread.
|
| ~Core();
|
|
|
| // The variables below should be used only on the I/O thread.
|
| - const WeakHandle<SyncNotifierObserver> delegate_observer_;
|
| + const WeakHandle<InvalidationHandler> delegate_observer_;
|
| scoped_ptr<InvalidationNotifier> invalidation_notifier_;
|
| scoped_refptr<base::SingleThreadTaskRunner> network_task_runner_;
|
|
|
| DISALLOW_COPY_AND_ASSIGN(Core);
|
| };
|
|
|
| -NonBlockingInvalidationNotifier::Core::Core(
|
| - const WeakHandle<SyncNotifierObserver>& delegate_observer)
|
| +NonBlockingInvalidator::Core::Core(
|
| + const WeakHandle<InvalidationHandler>& delegate_observer)
|
| : delegate_observer_(delegate_observer) {
|
| DCHECK(delegate_observer_.IsInitialized());
|
| }
|
|
|
| -NonBlockingInvalidationNotifier::Core::~Core() {
|
| +NonBlockingInvalidator::Core::~Core() {
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::Core::Initialize(
|
| +void NonBlockingInvalidator::Core::Initialize(
|
| const notifier::NotifierOptions& notifier_options,
|
| const InvalidationVersionMap& initial_max_invalidation_versions,
|
| const std::string& initial_invalidation_state,
|
| @@ -94,60 +94,58 @@ void NonBlockingInvalidationNotifier::Core::Initialize(
|
| invalidation_notifier_->RegisterHandler(this);
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::Core::Teardown() {
|
| +void NonBlockingInvalidator::Core::Teardown() {
|
| DCHECK(network_task_runner_->BelongsToCurrentThread());
|
| invalidation_notifier_->UnregisterHandler(this);
|
| invalidation_notifier_.reset();
|
| network_task_runner_ = NULL;
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::Core::UpdateRegisteredIds(
|
| - const ObjectIdSet& ids) {
|
| +void NonBlockingInvalidator::Core::UpdateRegisteredIds(const ObjectIdSet& ids) {
|
| DCHECK(network_task_runner_->BelongsToCurrentThread());
|
| invalidation_notifier_->UpdateRegisteredIds(this, ids);
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::Core::SetUniqueId(
|
| - const std::string& unique_id) {
|
| +void NonBlockingInvalidator::Core::SetUniqueId(const std::string& unique_id) {
|
| DCHECK(network_task_runner_->BelongsToCurrentThread());
|
| invalidation_notifier_->SetUniqueId(unique_id);
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::Core::SetStateDeprecated(
|
| +void NonBlockingInvalidator::Core::SetStateDeprecated(
|
| const std::string& state) {
|
| DCHECK(network_task_runner_->BelongsToCurrentThread());
|
| invalidation_notifier_->SetStateDeprecated(state);
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::Core::UpdateCredentials(
|
| - const std::string& email, const std::string& token) {
|
| +void NonBlockingInvalidator::Core::UpdateCredentials(const std::string& email,
|
| + const std::string& token) {
|
| DCHECK(network_task_runner_->BelongsToCurrentThread());
|
| invalidation_notifier_->UpdateCredentials(email, token);
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::Core::OnNotificationsEnabled() {
|
| +void NonBlockingInvalidator::Core::OnNotificationsEnabled() {
|
| DCHECK(network_task_runner_->BelongsToCurrentThread());
|
| delegate_observer_.Call(FROM_HERE,
|
| - &SyncNotifierObserver::OnNotificationsEnabled);
|
| + &InvalidationHandler::OnNotificationsEnabled);
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::Core::OnNotificationsDisabled(
|
| +void NonBlockingInvalidator::Core::OnNotificationsDisabled(
|
| NotificationsDisabledReason reason) {
|
| DCHECK(network_task_runner_->BelongsToCurrentThread());
|
| delegate_observer_.Call(
|
| - FROM_HERE, &SyncNotifierObserver::OnNotificationsDisabled, reason);
|
| + FROM_HERE, &InvalidationHandler::OnNotificationsDisabled, reason);
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::Core::OnIncomingNotification(
|
| +void NonBlockingInvalidator::Core::OnIncomingNotification(
|
| const ObjectIdStateMap& id_state_map, IncomingNotificationSource source) {
|
| DCHECK(network_task_runner_->BelongsToCurrentThread());
|
| delegate_observer_.Call(FROM_HERE,
|
| - &SyncNotifierObserver::OnIncomingNotification,
|
| + &InvalidationHandler::OnIncomingNotification,
|
| id_state_map,
|
| source);
|
| }
|
|
|
| -NonBlockingInvalidationNotifier::NonBlockingInvalidationNotifier(
|
| +NonBlockingInvalidator::NonBlockingInvalidator(
|
| const notifier::NotifierOptions& notifier_options,
|
| const InvalidationVersionMap& initial_max_invalidation_versions,
|
| const std::string& initial_invalidation_state,
|
| @@ -164,7 +162,7 @@ NonBlockingInvalidationNotifier::NonBlockingInvalidationNotifier(
|
| if (!network_task_runner_->PostTask(
|
| FROM_HERE,
|
| base::Bind(
|
| - &NonBlockingInvalidationNotifier::Core::Initialize,
|
| + &NonBlockingInvalidator::Core::Initialize,
|
| core_.get(),
|
| notifier_options,
|
| initial_max_invalidation_versions,
|
| @@ -175,96 +173,90 @@ NonBlockingInvalidationNotifier::NonBlockingInvalidationNotifier(
|
| }
|
| }
|
|
|
| -NonBlockingInvalidationNotifier::~NonBlockingInvalidationNotifier() {
|
| +NonBlockingInvalidator::~NonBlockingInvalidator() {
|
| DCHECK(parent_task_runner_->BelongsToCurrentThread());
|
| if (!network_task_runner_->PostTask(
|
| FROM_HERE,
|
| - base::Bind(&NonBlockingInvalidationNotifier::Core::Teardown,
|
| + base::Bind(&NonBlockingInvalidator::Core::Teardown,
|
| core_.get()))) {
|
| NOTREACHED();
|
| }
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::RegisterHandler(
|
| - SyncNotifierObserver* handler) {
|
| +void NonBlockingInvalidator::RegisterHandler(InvalidationHandler* handler) {
|
| DCHECK(parent_task_runner_->BelongsToCurrentThread());
|
| registrar_.RegisterHandler(handler);
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::UpdateRegisteredIds(
|
| - SyncNotifierObserver* handler,
|
| - const ObjectIdSet& ids) {
|
| +void NonBlockingInvalidator::UpdateRegisteredIds(InvalidationHandler* handler,
|
| + const ObjectIdSet& ids) {
|
| DCHECK(parent_task_runner_->BelongsToCurrentThread());
|
| registrar_.UpdateRegisteredIds(handler, ids);
|
| if (!network_task_runner_->PostTask(
|
| FROM_HERE,
|
| base::Bind(
|
| - &NonBlockingInvalidationNotifier::Core::UpdateRegisteredIds,
|
| + &NonBlockingInvalidator::Core::UpdateRegisteredIds,
|
| core_.get(),
|
| registrar_.GetAllRegisteredIds()))) {
|
| NOTREACHED();
|
| }
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::UnregisterHandler(
|
| - SyncNotifierObserver* handler) {
|
| +void NonBlockingInvalidator::UnregisterHandler(InvalidationHandler* handler) {
|
| DCHECK(parent_task_runner_->BelongsToCurrentThread());
|
| registrar_.UnregisterHandler(handler);
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::SetUniqueId(
|
| - const std::string& unique_id) {
|
| +void NonBlockingInvalidator::SetUniqueId(const std::string& unique_id) {
|
| DCHECK(parent_task_runner_->BelongsToCurrentThread());
|
| if (!network_task_runner_->PostTask(
|
| FROM_HERE,
|
| - base::Bind(&NonBlockingInvalidationNotifier::Core::SetUniqueId,
|
| + base::Bind(&NonBlockingInvalidator::Core::SetUniqueId,
|
| core_.get(), unique_id))) {
|
| NOTREACHED();
|
| }
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::SetStateDeprecated(
|
| - const std::string& state) {
|
| +void NonBlockingInvalidator::SetStateDeprecated(const std::string& state) {
|
| DCHECK(parent_task_runner_->BelongsToCurrentThread());
|
| if (!network_task_runner_->PostTask(
|
| FROM_HERE,
|
| base::Bind(
|
| - &NonBlockingInvalidationNotifier::Core::SetStateDeprecated,
|
| + &NonBlockingInvalidator::Core::SetStateDeprecated,
|
| core_.get(), state))) {
|
| NOTREACHED();
|
| }
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::UpdateCredentials(
|
| - const std::string& email, const std::string& token) {
|
| +void NonBlockingInvalidator::UpdateCredentials(const std::string& email,
|
| + const std::string& token) {
|
| DCHECK(parent_task_runner_->BelongsToCurrentThread());
|
| if (!network_task_runner_->PostTask(
|
| FROM_HERE,
|
| - base::Bind(&NonBlockingInvalidationNotifier::Core::UpdateCredentials,
|
| + base::Bind(&NonBlockingInvalidator::Core::UpdateCredentials,
|
| core_.get(), email, token))) {
|
| NOTREACHED();
|
| }
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::SendNotification(
|
| - ModelTypeSet changed_types) {
|
| +void NonBlockingInvalidator::SendNotification(ModelTypeSet changed_types) {
|
| DCHECK(parent_task_runner_->BelongsToCurrentThread());
|
| // InvalidationClient doesn't implement SendNotification(), so no
|
| // need to forward on the call.
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::OnNotificationsEnabled() {
|
| +void NonBlockingInvalidator::OnNotificationsEnabled() {
|
| DCHECK(parent_task_runner_->BelongsToCurrentThread());
|
| registrar_.EmitOnNotificationsEnabled();
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::OnNotificationsDisabled(
|
| +void NonBlockingInvalidator::OnNotificationsDisabled(
|
| NotificationsDisabledReason reason) {
|
| DCHECK(parent_task_runner_->BelongsToCurrentThread());
|
| registrar_.EmitOnNotificationsDisabled(reason);
|
| }
|
|
|
| -void NonBlockingInvalidationNotifier::OnIncomingNotification(
|
| +void NonBlockingInvalidator::OnIncomingNotification(
|
| const ObjectIdStateMap& id_state_map,
|
| IncomingNotificationSource source) {
|
| DCHECK(parent_task_runner_->BelongsToCurrentThread());
|
|
|