| Index: sync/notifier/sync_invalidation_client.cc
|
| diff --git a/sync/notifier/chrome_invalidation_client.cc b/sync/notifier/sync_invalidation_client.cc
|
| similarity index 86%
|
| rename from sync/notifier/chrome_invalidation_client.cc
|
| rename to sync/notifier/sync_invalidation_client.cc
|
| index e2f406d7760f4d16003fce73b442046b1544af31..7398912434441f182829239944d5b6f2ebc63a70 100644
|
| --- a/sync/notifier/chrome_invalidation_client.cc
|
| +++ b/sync/notifier/sync_invalidation_client.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_client.h"
|
|
|
| #include <string>
|
| #include <vector>
|
| @@ -26,13 +26,13 @@ const char kApplicationName[] = "chrome-sync";
|
|
|
| namespace syncer {
|
|
|
| -ChromeInvalidationClient::Listener::~Listener() {}
|
| +SyncInvalidationClient::Listener::~Listener() {}
|
|
|
| -ChromeInvalidationClient::ChromeInvalidationClient(
|
| +SyncInvalidationClient::SyncInvalidationClient(
|
| scoped_ptr<notifier::PushClient> push_client)
|
| : push_client_(push_client.get()),
|
| - chrome_system_resources_(push_client.Pass(),
|
| - ALLOW_THIS_IN_INITIALIZER_LIST(this)),
|
| + sync_system_resources_(push_client.Pass(),
|
| + ALLOW_THIS_IN_INITIALIZER_LIST(this)),
|
| listener_(NULL),
|
| ticl_state_(DEFAULT_NOTIFICATION_ERROR),
|
| push_client_state_(DEFAULT_NOTIFICATION_ERROR) {
|
| @@ -40,14 +40,14 @@ ChromeInvalidationClient::ChromeInvalidationClient(
|
| push_client_->AddObserver(this);
|
| }
|
|
|
| -ChromeInvalidationClient::~ChromeInvalidationClient() {
|
| +SyncInvalidationClient::~SyncInvalidationClient() {
|
| DCHECK(CalledOnValidThread());
|
| push_client_->RemoveObserver(this);
|
| Stop();
|
| DCHECK(!listener_);
|
| }
|
|
|
| -void ChromeInvalidationClient::Start(
|
| +void SyncInvalidationClient::Start(
|
| const CreateInvalidationClientCallback&
|
| create_invalidation_client_callback,
|
| const std::string& client_id, const std::string& client_info,
|
| @@ -58,13 +58,13 @@ void ChromeInvalidationClient::Start(
|
| 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()) {
|
| @@ -88,7 +88,7 @@ void ChromeInvalidationClient::Start(
|
| 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 SyncInvalidationClient::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 SyncInvalidationClient::UpdateRegisteredIds(const ObjectIdSet& ids) {
|
| DCHECK(CalledOnValidThread());
|
| registered_ids_ = ids;
|
| // |ticl_state_| can go to NO_NOTIFICATION_ERROR even without a
|
| @@ -114,7 +114,7 @@ void ChromeInvalidationClient::UpdateRegisteredIds(const ObjectIdSet& ids) {
|
| // TODO(akalin): Clear invalidation versions for unregistered types.
|
| }
|
|
|
| -void ChromeInvalidationClient::Ready(
|
| +void SyncInvalidationClient::Ready(
|
| invalidation::InvalidationClient* client) {
|
| DCHECK(CalledOnValidThread());
|
| DCHECK_EQ(client, invalidation_client_.get());
|
| @@ -123,7 +123,7 @@ void ChromeInvalidationClient::Ready(
|
| registration_manager_->UpdateRegisteredIds(registered_ids_);
|
| }
|
|
|
| -void ChromeInvalidationClient::Invalidate(
|
| +void SyncInvalidationClient::Invalidate(
|
| invalidation::InvalidationClient* client,
|
| const invalidation::Invalidation& invalidation,
|
| const invalidation::AckHandle& ack_handle) {
|
| @@ -170,7 +170,7 @@ void ChromeInvalidationClient::Invalidate(
|
| client->Acknowledge(ack_handle);
|
| }
|
|
|
| -void ChromeInvalidationClient::InvalidateUnknownVersion(
|
| +void SyncInvalidationClient::InvalidateUnknownVersion(
|
| invalidation::InvalidationClient* client,
|
| const invalidation::ObjectId& object_id,
|
| const invalidation::AckHandle& ack_handle) {
|
| @@ -188,7 +188,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 SyncInvalidationClient::InvalidateAll(
|
| invalidation::InvalidationClient* client,
|
| const invalidation::AckHandle& ack_handle) {
|
| DCHECK(CalledOnValidThread());
|
| @@ -206,13 +206,13 @@ void ChromeInvalidationClient::InvalidateAll(
|
| client->Acknowledge(ack_handle);
|
| }
|
|
|
| -void ChromeInvalidationClient::EmitInvalidation(
|
| +void SyncInvalidationClient::EmitInvalidation(
|
| const ObjectIdStateMap& id_state_map) {
|
| DCHECK(CalledOnValidThread());
|
| listener_->OnInvalidate(id_state_map);
|
| }
|
|
|
| -void ChromeInvalidationClient::InformRegistrationStatus(
|
| +void SyncInvalidationClient::InformRegistrationStatus(
|
| invalidation::InvalidationClient* client,
|
| const invalidation::ObjectId& object_id,
|
| InvalidationListener::RegistrationState new_state) {
|
| @@ -227,7 +227,7 @@ void ChromeInvalidationClient::InformRegistrationStatus(
|
| }
|
| }
|
|
|
| -void ChromeInvalidationClient::InformRegistrationFailure(
|
| +void SyncInvalidationClient::InformRegistrationFailure(
|
| invalidation::InvalidationClient* client,
|
| const invalidation::ObjectId& object_id,
|
| bool is_transient,
|
| @@ -252,7 +252,7 @@ void ChromeInvalidationClient::InformRegistrationFailure(
|
| }
|
| }
|
|
|
| -void ChromeInvalidationClient::ReissueRegistrations(
|
| +void SyncInvalidationClient::ReissueRegistrations(
|
| invalidation::InvalidationClient* client,
|
| const std::string& prefix,
|
| int prefix_length) {
|
| @@ -262,7 +262,7 @@ void ChromeInvalidationClient::ReissueRegistrations(
|
| registration_manager_->MarkAllRegistrationsLost();
|
| }
|
|
|
| -void ChromeInvalidationClient::InformError(
|
| +void SyncInvalidationClient::InformError(
|
| invalidation::InvalidationClient* client,
|
| const invalidation::ErrorInfo& error_info) {
|
| DCHECK(CalledOnValidThread());
|
| @@ -278,26 +278,26 @@ void ChromeInvalidationClient::InformError(
|
| EmitStateChange();
|
| }
|
|
|
| -void ChromeInvalidationClient::WriteState(const std::string& state) {
|
| +void SyncInvalidationClient::WriteState(const std::string& state) {
|
| DCHECK(CalledOnValidThread());
|
| DVLOG(1) << "WriteState";
|
| invalidation_state_tracker_.Call(
|
| FROM_HERE, &InvalidationStateTracker::SetInvalidationState, state);
|
| }
|
|
|
| -void ChromeInvalidationClient::StopForTest() {
|
| +void SyncInvalidationClient::StopForTest() {
|
| DCHECK(CalledOnValidThread());
|
| Stop();
|
| }
|
|
|
| -void ChromeInvalidationClient::Stop() {
|
| +void SyncInvalidationClient::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();
|
| @@ -309,7 +309,7 @@ void ChromeInvalidationClient::Stop() {
|
| push_client_state_ = DEFAULT_NOTIFICATION_ERROR;
|
| }
|
|
|
| -NotificationsDisabledReason ChromeInvalidationClient::GetState() const {
|
| +NotificationsDisabledReason SyncInvalidationClient::GetState() const {
|
| DCHECK(CalledOnValidThread());
|
| if (ticl_state_ == NOTIFICATION_CREDENTIALS_REJECTED ||
|
| push_client_state_ == NOTIFICATION_CREDENTIALS_REJECTED) {
|
| @@ -327,7 +327,7 @@ NotificationsDisabledReason ChromeInvalidationClient::GetState() const {
|
| return TRANSIENT_NOTIFICATION_ERROR;
|
| }
|
|
|
| -void ChromeInvalidationClient::EmitStateChange() {
|
| +void SyncInvalidationClient::EmitStateChange() {
|
| DCHECK(CalledOnValidThread());
|
| if (GetState() == NO_NOTIFICATION_ERROR) {
|
| listener_->OnNotificationsEnabled();
|
| @@ -336,20 +336,20 @@ void ChromeInvalidationClient::EmitStateChange() {
|
| }
|
| }
|
|
|
| -void ChromeInvalidationClient::OnNotificationsEnabled() {
|
| +void SyncInvalidationClient::OnNotificationsEnabled() {
|
| DCHECK(CalledOnValidThread());
|
| push_client_state_ = NO_NOTIFICATION_ERROR;
|
| EmitStateChange();
|
| }
|
|
|
| -void ChromeInvalidationClient::OnNotificationsDisabled(
|
| +void SyncInvalidationClient::OnNotificationsDisabled(
|
| notifier::NotificationsDisabledReason reason) {
|
| DCHECK(CalledOnValidThread());
|
| push_client_state_ = FromNotifierReason(reason);
|
| EmitStateChange();
|
| }
|
|
|
| -void ChromeInvalidationClient::OnIncomingNotification(
|
| +void SyncInvalidationClient::OnIncomingNotification(
|
| const notifier::Notification& notification) {
|
| DCHECK(CalledOnValidThread());
|
| // Do nothing, since this is already handled by |invalidation_client_|.
|
|
|