| Index: sync/notifier/sync_invalidation_listener.cc
|
| diff --git a/sync/notifier/chrome_invalidation_client.cc b/sync/notifier/sync_invalidation_listener.cc
|
| similarity index 84%
|
| rename from sync/notifier/chrome_invalidation_client.cc
|
| rename to sync/notifier/sync_invalidation_listener.cc
|
| index 938f7e679bb922c711acc1b4957eb4ca14a5182f..b75b15c14a756f2c308c1663d78fe1e0ab4cd488 100644
|
| --- a/sync/notifier/chrome_invalidation_client.cc
|
| +++ b/sync/notifier/sync_invalidation_listener.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/chrome_invalidation_client.h"
|
| +#include "sync/notifier/sync_invalidation_listener.h"
|
|
|
| #include <string>
|
| #include <vector>
|
| @@ -26,45 +26,45 @@ const char kApplicationName[] = "chrome-sync";
|
|
|
| namespace syncer {
|
|
|
| -ChromeInvalidationClient::Listener::~Listener() {}
|
| +SyncInvalidationListener::Delegate::~Delegate() {}
|
|
|
| -ChromeInvalidationClient::ChromeInvalidationClient(
|
| +SyncInvalidationListener::SyncInvalidationListener(
|
| scoped_ptr<notifier::PushClient> push_client)
|
| : push_client_(push_client.get()),
|
| - chrome_system_resources_(push_client.Pass(),
|
| - ALLOW_THIS_IN_INITIALIZER_LIST(this)),
|
| - listener_(NULL),
|
| + sync_system_resources_(push_client.Pass(),
|
| + ALLOW_THIS_IN_INITIALIZER_LIST(this)),
|
| + delegate_(NULL),
|
| ticl_state_(DEFAULT_NOTIFICATION_ERROR),
|
| push_client_state_(DEFAULT_NOTIFICATION_ERROR) {
|
| DCHECK(CalledOnValidThread());
|
| push_client_->AddObserver(this);
|
| }
|
|
|
| -ChromeInvalidationClient::~ChromeInvalidationClient() {
|
| +SyncInvalidationListener::~SyncInvalidationListener() {
|
| DCHECK(CalledOnValidThread());
|
| push_client_->RemoveObserver(this);
|
| Stop();
|
| - DCHECK(!listener_);
|
| + DCHECK(!delegate_);
|
| }
|
|
|
| -void ChromeInvalidationClient::Start(
|
| +void SyncInvalidationListener::Start(
|
| const CreateInvalidationClientCallback&
|
| create_invalidation_client_callback,
|
| const std::string& client_id, const std::string& client_info,
|
| const std::string& state,
|
| const InvalidationVersionMap& initial_max_invalidation_versions,
|
| const WeakHandle<InvalidationStateTracker>& invalidation_state_tracker,
|
| - Listener* listener) {
|
| + Delegate* delegate) {
|
| DCHECK(CalledOnValidThread());
|
| Stop();
|
|
|
| - chrome_system_resources_.set_platform(client_info);
|
| - chrome_system_resources_.Start();
|
| + sync_system_resources_.set_platform(client_info);
|
| + sync_system_resources_.Start();
|
|
|
| // The Storage resource is implemented as a write-through cache. We populate
|
| // it with the initial state on startup, so subsequent writes go to disk and
|
| // update the in-memory cache, while reads just return the cached state.
|
| - chrome_system_resources_.storage()->SetInitialState(state);
|
| + sync_system_resources_.storage()->SetInitialState(state);
|
|
|
| max_invalidation_versions_ = initial_max_invalidation_versions;
|
| if (max_invalidation_versions_.empty()) {
|
| @@ -81,14 +81,14 @@ void ChromeInvalidationClient::Start(
|
| invalidation_state_tracker_ = invalidation_state_tracker;
|
| DCHECK(invalidation_state_tracker_.IsInitialized());
|
|
|
| - DCHECK(!listener_);
|
| - DCHECK(listener);
|
| - listener_ = listener;
|
| + DCHECK(!delegate_);
|
| + DCHECK(delegate);
|
| + delegate_ = delegate;
|
|
|
| int client_type = ipc::invalidation::ClientType::CHROME_SYNC;
|
| invalidation_client_.reset(
|
| create_invalidation_client_callback.Run(
|
| - &chrome_system_resources_, client_type, client_id,
|
| + &sync_system_resources_, client_type, client_id,
|
| kApplicationName, this));
|
| invalidation_client_->Start();
|
|
|
| @@ -96,13 +96,13 @@ void ChromeInvalidationClient::Start(
|
| new RegistrationManager(invalidation_client_.get()));
|
| }
|
|
|
| -void ChromeInvalidationClient::UpdateCredentials(
|
| +void SyncInvalidationListener::UpdateCredentials(
|
| const std::string& email, const std::string& token) {
|
| DCHECK(CalledOnValidThread());
|
| - chrome_system_resources_.network()->UpdateCredentials(email, token);
|
| + sync_system_resources_.network()->UpdateCredentials(email, token);
|
| }
|
|
|
| -void ChromeInvalidationClient::UpdateRegisteredIds(const ObjectIdSet& ids) {
|
| +void SyncInvalidationListener::UpdateRegisteredIds(const ObjectIdSet& ids) {
|
| DCHECK(CalledOnValidThread());
|
| registered_ids_ = ids;
|
| // |ticl_state_| can go to NO_NOTIFICATION_ERROR even without a
|
| @@ -113,7 +113,7 @@ void ChromeInvalidationClient::UpdateRegisteredIds(const ObjectIdSet& ids) {
|
| }
|
| }
|
|
|
| -void ChromeInvalidationClient::Ready(
|
| +void SyncInvalidationListener::Ready(
|
| invalidation::InvalidationClient* client) {
|
| DCHECK(CalledOnValidThread());
|
| DCHECK_EQ(client, invalidation_client_.get());
|
| @@ -122,7 +122,7 @@ void ChromeInvalidationClient::Ready(
|
| DoRegistrationUpdate();
|
| }
|
|
|
| -void ChromeInvalidationClient::Invalidate(
|
| +void SyncInvalidationListener::Invalidate(
|
| invalidation::InvalidationClient* client,
|
| const invalidation::Invalidation& invalidation,
|
| const invalidation::AckHandle& ack_handle) {
|
| @@ -169,7 +169,7 @@ void ChromeInvalidationClient::Invalidate(
|
| client->Acknowledge(ack_handle);
|
| }
|
|
|
| -void ChromeInvalidationClient::InvalidateUnknownVersion(
|
| +void SyncInvalidationListener::InvalidateUnknownVersion(
|
| invalidation::InvalidationClient* client,
|
| const invalidation::ObjectId& object_id,
|
| const invalidation::AckHandle& ack_handle) {
|
| @@ -187,7 +187,7 @@ void ChromeInvalidationClient::InvalidateUnknownVersion(
|
|
|
| // This should behave as if we got an invalidation with version
|
| // UNKNOWN_OBJECT_VERSION for all known data types.
|
| -void ChromeInvalidationClient::InvalidateAll(
|
| +void SyncInvalidationListener::InvalidateAll(
|
| invalidation::InvalidationClient* client,
|
| const invalidation::AckHandle& ack_handle) {
|
| DCHECK(CalledOnValidThread());
|
| @@ -205,13 +205,13 @@ void ChromeInvalidationClient::InvalidateAll(
|
| client->Acknowledge(ack_handle);
|
| }
|
|
|
| -void ChromeInvalidationClient::EmitInvalidation(
|
| +void SyncInvalidationListener::EmitInvalidation(
|
| const ObjectIdStateMap& id_state_map) {
|
| DCHECK(CalledOnValidThread());
|
| - listener_->OnInvalidate(id_state_map);
|
| + delegate_->OnInvalidate(id_state_map);
|
| }
|
|
|
| -void ChromeInvalidationClient::InformRegistrationStatus(
|
| +void SyncInvalidationListener::InformRegistrationStatus(
|
| invalidation::InvalidationClient* client,
|
| const invalidation::ObjectId& object_id,
|
| InvalidationListener::RegistrationState new_state) {
|
| @@ -226,7 +226,7 @@ void ChromeInvalidationClient::InformRegistrationStatus(
|
| }
|
| }
|
|
|
| -void ChromeInvalidationClient::InformRegistrationFailure(
|
| +void SyncInvalidationListener::InformRegistrationFailure(
|
| invalidation::InvalidationClient* client,
|
| const invalidation::ObjectId& object_id,
|
| bool is_transient,
|
| @@ -255,7 +255,7 @@ void ChromeInvalidationClient::InformRegistrationFailure(
|
| }
|
| }
|
|
|
| -void ChromeInvalidationClient::ReissueRegistrations(
|
| +void SyncInvalidationListener::ReissueRegistrations(
|
| invalidation::InvalidationClient* client,
|
| const std::string& prefix,
|
| int prefix_length) {
|
| @@ -265,7 +265,7 @@ void ChromeInvalidationClient::ReissueRegistrations(
|
| registration_manager_->MarkAllRegistrationsLost();
|
| }
|
|
|
| -void ChromeInvalidationClient::InformError(
|
| +void SyncInvalidationListener::InformError(
|
| invalidation::InvalidationClient* client,
|
| const invalidation::ErrorInfo& error_info) {
|
| DCHECK(CalledOnValidThread());
|
| @@ -281,14 +281,14 @@ void ChromeInvalidationClient::InformError(
|
| EmitStateChange();
|
| }
|
|
|
| -void ChromeInvalidationClient::WriteState(const std::string& state) {
|
| +void SyncInvalidationListener::WriteState(const std::string& state) {
|
| DCHECK(CalledOnValidThread());
|
| DVLOG(1) << "WriteState";
|
| invalidation_state_tracker_.Call(
|
| FROM_HERE, &InvalidationStateTracker::SetInvalidationState, state);
|
| }
|
|
|
| -void ChromeInvalidationClient::DoRegistrationUpdate() {
|
| +void SyncInvalidationListener::DoRegistrationUpdate() {
|
| DCHECK(CalledOnValidThread());
|
| const ObjectIdSet& unregistered_ids =
|
| registration_manager_->UpdateRegisteredIds(registered_ids_);
|
| @@ -296,23 +296,23 @@ void ChromeInvalidationClient::DoRegistrationUpdate() {
|
| FROM_HERE, &InvalidationStateTracker::Forget, unregistered_ids);
|
| }
|
|
|
| -void ChromeInvalidationClient::StopForTest() {
|
| +void SyncInvalidationListener::StopForTest() {
|
| DCHECK(CalledOnValidThread());
|
| Stop();
|
| }
|
|
|
| -void ChromeInvalidationClient::Stop() {
|
| +void SyncInvalidationListener::Stop() {
|
| DCHECK(CalledOnValidThread());
|
| if (!invalidation_client_.get()) {
|
| return;
|
| }
|
|
|
| registration_manager_.reset();
|
| - chrome_system_resources_.Stop();
|
| + sync_system_resources_.Stop();
|
| invalidation_client_->Stop();
|
|
|
| invalidation_client_.reset();
|
| - listener_ = NULL;
|
| + delegate_ = NULL;
|
|
|
| invalidation_state_tracker_.Reset();
|
| max_invalidation_versions_.clear();
|
| @@ -320,7 +320,7 @@ void ChromeInvalidationClient::Stop() {
|
| push_client_state_ = DEFAULT_NOTIFICATION_ERROR;
|
| }
|
|
|
| -NotificationsDisabledReason ChromeInvalidationClient::GetState() const {
|
| +NotificationsDisabledReason SyncInvalidationListener::GetState() const {
|
| DCHECK(CalledOnValidThread());
|
| if (ticl_state_ == NOTIFICATION_CREDENTIALS_REJECTED ||
|
| push_client_state_ == NOTIFICATION_CREDENTIALS_REJECTED) {
|
| @@ -338,29 +338,29 @@ NotificationsDisabledReason ChromeInvalidationClient::GetState() const {
|
| return TRANSIENT_NOTIFICATION_ERROR;
|
| }
|
|
|
| -void ChromeInvalidationClient::EmitStateChange() {
|
| +void SyncInvalidationListener::EmitStateChange() {
|
| DCHECK(CalledOnValidThread());
|
| if (GetState() == NO_NOTIFICATION_ERROR) {
|
| - listener_->OnNotificationsEnabled();
|
| + delegate_->OnNotificationsEnabled();
|
| } else {
|
| - listener_->OnNotificationsDisabled(GetState());
|
| + delegate_->OnNotificationsDisabled(GetState());
|
| }
|
| }
|
|
|
| -void ChromeInvalidationClient::OnNotificationsEnabled() {
|
| +void SyncInvalidationListener::OnNotificationsEnabled() {
|
| DCHECK(CalledOnValidThread());
|
| push_client_state_ = NO_NOTIFICATION_ERROR;
|
| EmitStateChange();
|
| }
|
|
|
| -void ChromeInvalidationClient::OnNotificationsDisabled(
|
| +void SyncInvalidationListener::OnNotificationsDisabled(
|
| notifier::NotificationsDisabledReason reason) {
|
| DCHECK(CalledOnValidThread());
|
| push_client_state_ = FromNotifierReason(reason);
|
| EmitStateChange();
|
| }
|
|
|
| -void ChromeInvalidationClient::OnIncomingNotification(
|
| +void SyncInvalidationListener::OnIncomingNotification(
|
| const notifier::Notification& notification) {
|
| DCHECK(CalledOnValidThread());
|
| // Do nothing, since this is already handled by |invalidation_client_|.
|
|
|