Commit 53f218e1 authored by munjal@chromium.org's avatar munjal@chromium.org

Rename InvalidationVersionTracker to InvalidationStateTracker in preparation

to add more methods to that class.

BUG=124140
Review URL: https://chromiumcodereview.appspot.com/10407014

git-svn-id: svn://svn.chromium.org/chrome/trunk/src@137685 0039d316-1c4b-4281-b951-d872f2087c98
parent bcce9cc2
...@@ -312,7 +312,7 @@ SyncBackendHost::SyncBackendHost(Profile* profile) ...@@ -312,7 +312,7 @@ SyncBackendHost::SyncBackendHost(Profile* profile)
ParseNotifierOptions(*CommandLine::ForCurrentProcess(), ParseNotifierOptions(*CommandLine::ForCurrentProcess(),
profile_->GetRequestContext()), profile_->GetRequestContext()),
content::GetUserAgent(GURL()), content::GetUserAgent(GURL()),
base::WeakPtr<sync_notifier::InvalidationVersionTracker>()), base::WeakPtr<sync_notifier::InvalidationStateTracker>()),
frontend_(NULL) { frontend_(NULL) {
} }
......
...@@ -14,7 +14,7 @@ ...@@ -14,7 +14,7 @@
#include "base/time.h" #include "base/time.h"
#include "chrome/browser/prefs/pref_member.h" #include "chrome/browser/prefs/pref_member.h"
#include "content/public/browser/notification_observer.h" #include "content/public/browser/notification_observer.h"
#include "sync/notifier/invalidation_version_tracker.h" #include "sync/notifier/invalidation_state_tracker.h"
#include "sync/syncable/model_type.h" #include "sync/syncable/model_type.h"
class PrefService; class PrefService;
...@@ -45,7 +45,7 @@ class SyncPrefObserver { ...@@ -45,7 +45,7 @@ class SyncPrefObserver {
// sync_setup_wizard_unittest.cc // sync_setup_wizard_unittest.cc
// two_client_preferences_sync_test.cc // two_client_preferences_sync_test.cc
class SyncPrefs : public base::SupportsWeakPtr<SyncPrefs>, class SyncPrefs : public base::SupportsWeakPtr<SyncPrefs>,
public sync_notifier::InvalidationVersionTracker, public sync_notifier::InvalidationStateTracker,
public content::NotificationObserver { public content::NotificationObserver {
public: public:
// |pref_service| may be NULL (for unit tests), but in that case no // |pref_service| may be NULL (for unit tests), but in that case no
...@@ -106,7 +106,7 @@ class SyncPrefs : public base::SupportsWeakPtr<SyncPrefs>, ...@@ -106,7 +106,7 @@ class SyncPrefs : public base::SupportsWeakPtr<SyncPrefs>,
void SetSpareBootstrapToken(const std::string& token); void SetSpareBootstrapToken(const std::string& token);
#endif #endif
// InvalidationVersionTracker implementation. // InvalidationStateTracker implementation.
virtual sync_notifier::InvalidationVersionMap virtual sync_notifier::InvalidationVersionMap
GetAllMaxVersions() const OVERRIDE; GetAllMaxVersions() const OVERRIDE;
virtual void SetMaxVersion(syncable::ModelType model_type, virtual void SetMaxVersion(syncable::ModelType model_type,
......
...@@ -48,8 +48,8 @@ void ChromeInvalidationClient::Start( ...@@ -48,8 +48,8 @@ void ChromeInvalidationClient::Start(
const std::string& client_id, const std::string& client_info, const std::string& client_id, const std::string& client_info,
const std::string& state, const std::string& state,
const InvalidationVersionMap& initial_max_invalidation_versions, const InvalidationVersionMap& initial_max_invalidation_versions,
const browser_sync::WeakHandle<InvalidationVersionTracker>& const browser_sync::WeakHandle<InvalidationStateTracker>&
invalidation_version_tracker, invalidation_state_tracker,
Listener* listener, Listener* listener,
StateWriter* state_writer, StateWriter* state_writer,
base::WeakPtr<buzz::XmppTaskParentInterface> base_task) { base::WeakPtr<buzz::XmppTaskParentInterface> base_task) {
...@@ -76,8 +76,8 @@ void ChromeInvalidationClient::Start( ...@@ -76,8 +76,8 @@ void ChromeInvalidationClient::Start(
<< it->second; << it->second;
} }
} }
invalidation_version_tracker_ = invalidation_version_tracker; invalidation_state_tracker_ = invalidation_state_tracker;
DCHECK(invalidation_version_tracker_.IsInitialized()); DCHECK(invalidation_state_tracker_.IsInitialized());
DCHECK(!listener_); DCHECK(!listener_);
DCHECK(listener); DCHECK(listener);
...@@ -124,7 +124,7 @@ void ChromeInvalidationClient::Stop() { ...@@ -124,7 +124,7 @@ void ChromeInvalidationClient::Stop() {
state_writer_ = NULL; state_writer_ = NULL;
listener_ = NULL; listener_ = NULL;
invalidation_version_tracker_.Reset(); invalidation_state_tracker_.Reset();
max_invalidation_versions_.clear(); max_invalidation_versions_.clear();
} }
...@@ -178,9 +178,9 @@ void ChromeInvalidationClient::Invalidate( ...@@ -178,9 +178,9 @@ void ChromeInvalidationClient::Invalidate(
<< syncable::ModelTypeToString(model_type) << " to " << syncable::ModelTypeToString(model_type) << " to "
<< invalidation.version(); << invalidation.version();
max_invalidation_versions_[model_type] = invalidation.version(); max_invalidation_versions_[model_type] = invalidation.version();
invalidation_version_tracker_.Call( invalidation_state_tracker_.Call(
FROM_HERE, FROM_HERE,
&InvalidationVersionTracker::SetMaxVersion, &InvalidationStateTracker::SetMaxVersion,
model_type, invalidation.version()); model_type, invalidation.version());
std::string payload; std::string payload;
......
...@@ -18,7 +18,7 @@ ...@@ -18,7 +18,7 @@
#include "base/threading/non_thread_safe.h" #include "base/threading/non_thread_safe.h"
#include "google/cacheinvalidation/include/invalidation-listener.h" #include "google/cacheinvalidation/include/invalidation-listener.h"
#include "sync/notifier/chrome_system_resources.h" #include "sync/notifier/chrome_system_resources.h"
#include "sync/notifier/invalidation_version_tracker.h" #include "sync/notifier/invalidation_state_tracker.h"
#include "sync/notifier/state_writer.h" #include "sync/notifier/state_writer.h"
#include "sync/syncable/model_type.h" #include "sync/syncable/model_type.h"
#include "sync/syncable/model_type_payload_map.h" #include "sync/syncable/model_type_payload_map.h"
...@@ -57,14 +57,14 @@ class ChromeInvalidationClient ...@@ -57,14 +57,14 @@ class ChromeInvalidationClient
virtual ~ChromeInvalidationClient(); virtual ~ChromeInvalidationClient();
// Does not take ownership of |listener| or |state_writer|. // Does not take ownership of |listener| or |state_writer|.
// |invalidation_version_tracker| must be initialized. // |invalidation_state_tracker| must be initialized.
// |base_task| must still be non-NULL. // |base_task| must still be non-NULL.
void Start( void Start(
const std::string& client_id, const std::string& client_info, const std::string& client_id, const std::string& client_info,
const std::string& state, const std::string& state,
const InvalidationVersionMap& initial_max_invalidation_versions, const InvalidationVersionMap& initial_max_invalidation_versions,
const browser_sync::WeakHandle<InvalidationVersionTracker>& const browser_sync::WeakHandle<InvalidationStateTracker>&
invalidation_version_tracker, invalidation_state_tracker,
Listener* listener, Listener* listener,
StateWriter* state_writer, StateWriter* state_writer,
base::WeakPtr<buzz::XmppTaskParentInterface> base_task); base::WeakPtr<buzz::XmppTaskParentInterface> base_task);
...@@ -122,8 +122,8 @@ class ChromeInvalidationClient ...@@ -122,8 +122,8 @@ class ChromeInvalidationClient
base::NonThreadSafe non_thread_safe_; base::NonThreadSafe non_thread_safe_;
ChromeSystemResources chrome_system_resources_; ChromeSystemResources chrome_system_resources_;
InvalidationVersionMap max_invalidation_versions_; InvalidationVersionMap max_invalidation_versions_;
browser_sync::WeakHandle<InvalidationVersionTracker> browser_sync::WeakHandle<InvalidationStateTracker>
invalidation_version_tracker_; invalidation_state_tracker_;
Listener* listener_; Listener* listener_;
StateWriter* state_writer_; StateWriter* state_writer_;
scoped_ptr<invalidation::InvalidationClient> invalidation_client_; scoped_ptr<invalidation::InvalidationClient> invalidation_client_;
......
...@@ -46,9 +46,9 @@ class MockListener : public ChromeInvalidationClient::Listener { ...@@ -46,9 +46,9 @@ class MockListener : public ChromeInvalidationClient::Listener {
MOCK_METHOD1(OnSessionStatusChanged, void(bool)); MOCK_METHOD1(OnSessionStatusChanged, void(bool));
}; };
class MockInvalidationVersionTracker class MockInvalidationStateTracker
: public InvalidationVersionTracker, : public InvalidationStateTracker,
public base::SupportsWeakPtr<MockInvalidationVersionTracker> { public base::SupportsWeakPtr<MockInvalidationStateTracker> {
public: public:
MOCK_CONST_METHOD0(GetAllMaxVersions, InvalidationVersionMap()); MOCK_CONST_METHOD0(GetAllMaxVersions, InvalidationVersionMap());
MOCK_METHOD2(SetMaxVersion, void(syncable::ModelType, int64)); MOCK_METHOD2(SetMaxVersion, void(syncable::ModelType, int64));
...@@ -67,7 +67,7 @@ class ChromeInvalidationClientTest : public testing::Test { ...@@ -67,7 +67,7 @@ class ChromeInvalidationClientTest : public testing::Test {
client_.Start(kClientId, kClientInfo, kState, client_.Start(kClientId, kClientInfo, kState,
InvalidationVersionMap(), InvalidationVersionMap(),
browser_sync::MakeWeakHandle( browser_sync::MakeWeakHandle(
mock_invalidation_version_tracker_.AsWeakPtr()), mock_invalidation_state_tracker_.AsWeakPtr()),
&mock_listener_, &mock_state_writer_, &mock_listener_, &mock_state_writer_,
fake_base_task_.AsWeakPtr()); fake_base_task_.AsWeakPtr());
} }
...@@ -98,7 +98,7 @@ class ChromeInvalidationClientTest : public testing::Test { ...@@ -98,7 +98,7 @@ class ChromeInvalidationClientTest : public testing::Test {
EXPECT_CALL(mock_invalidation_client_, Acknowledge(ack_handle)); EXPECT_CALL(mock_invalidation_client_, Acknowledge(ack_handle));
client_.Invalidate(&mock_invalidation_client_, inv, ack_handle); client_.Invalidate(&mock_invalidation_client_, inv, ack_handle);
// Pump message loop to trigger // Pump message loop to trigger
// InvalidationVersionTracker::SetMaxVersion(). // InvalidationStateTracker::SetMaxVersion().
message_loop_.RunAllPending(); message_loop_.RunAllPending();
} }
...@@ -121,8 +121,8 @@ class ChromeInvalidationClientTest : public testing::Test { ...@@ -121,8 +121,8 @@ class ChromeInvalidationClientTest : public testing::Test {
MessageLoop message_loop_; MessageLoop message_loop_;
StrictMock<MockListener> mock_listener_; StrictMock<MockListener> mock_listener_;
StrictMock<MockInvalidationVersionTracker> StrictMock<MockInvalidationStateTracker>
mock_invalidation_version_tracker_; mock_invalidation_state_tracker_;
StrictMock<MockStateWriter> mock_state_writer_; StrictMock<MockStateWriter> mock_state_writer_;
StrictMock<MockInvalidationClient> mock_invalidation_client_; StrictMock<MockInvalidationClient> mock_invalidation_client_;
notifier::FakeBaseTask fake_base_task_; notifier::FakeBaseTask fake_base_task_;
...@@ -156,7 +156,7 @@ TEST_F(ChromeInvalidationClientTest, InvalidateBadObjectId) { ...@@ -156,7 +156,7 @@ TEST_F(ChromeInvalidationClientTest, InvalidateBadObjectId) {
TEST_F(ChromeInvalidationClientTest, InvalidateNoPayload) { TEST_F(ChromeInvalidationClientTest, InvalidateNoPayload) {
EXPECT_CALL(mock_listener_, EXPECT_CALL(mock_listener_,
OnInvalidate(MakeMap(syncable::BOOKMARKS, ""))); OnInvalidate(MakeMap(syncable::BOOKMARKS, "")));
EXPECT_CALL(mock_invalidation_version_tracker_, EXPECT_CALL(mock_invalidation_state_tracker_,
SetMaxVersion(syncable::BOOKMARKS, 1)); SetMaxVersion(syncable::BOOKMARKS, 1));
FireInvalidate("BOOKMARK", 1, NULL); FireInvalidate("BOOKMARK", 1, NULL);
} }
...@@ -164,7 +164,7 @@ TEST_F(ChromeInvalidationClientTest, InvalidateNoPayload) { ...@@ -164,7 +164,7 @@ TEST_F(ChromeInvalidationClientTest, InvalidateNoPayload) {
TEST_F(ChromeInvalidationClientTest, InvalidateWithPayload) { TEST_F(ChromeInvalidationClientTest, InvalidateWithPayload) {
EXPECT_CALL(mock_listener_, EXPECT_CALL(mock_listener_,
OnInvalidate(MakeMap(syncable::PREFERENCES, "payload"))); OnInvalidate(MakeMap(syncable::PREFERENCES, "payload")));
EXPECT_CALL(mock_invalidation_version_tracker_, EXPECT_CALL(mock_invalidation_state_tracker_,
SetMaxVersion(syncable::PREFERENCES, 1)); SetMaxVersion(syncable::PREFERENCES, 1));
FireInvalidate("PREFERENCE", 1, "payload"); FireInvalidate("PREFERENCE", 1, "payload");
} }
...@@ -174,7 +174,7 @@ TEST_F(ChromeInvalidationClientTest, InvalidateVersion) { ...@@ -174,7 +174,7 @@ TEST_F(ChromeInvalidationClientTest, InvalidateVersion) {
EXPECT_CALL(mock_listener_, EXPECT_CALL(mock_listener_,
OnInvalidate(MakeMap(syncable::APPS, ""))); OnInvalidate(MakeMap(syncable::APPS, "")));
EXPECT_CALL(mock_invalidation_version_tracker_, EXPECT_CALL(mock_invalidation_state_tracker_,
SetMaxVersion(syncable::APPS, 1)); SetMaxVersion(syncable::APPS, 1));
// Should trigger. // Should trigger.
...@@ -207,9 +207,9 @@ TEST_F(ChromeInvalidationClientTest, InvalidateVersionMultipleTypes) { ...@@ -207,9 +207,9 @@ TEST_F(ChromeInvalidationClientTest, InvalidateVersionMultipleTypes) {
EXPECT_CALL(mock_listener_, EXPECT_CALL(mock_listener_,
OnInvalidate(MakeMap(syncable::EXTENSIONS, ""))); OnInvalidate(MakeMap(syncable::EXTENSIONS, "")));
EXPECT_CALL(mock_invalidation_version_tracker_, EXPECT_CALL(mock_invalidation_state_tracker_,
SetMaxVersion(syncable::APPS, 3)); SetMaxVersion(syncable::APPS, 3));
EXPECT_CALL(mock_invalidation_version_tracker_, EXPECT_CALL(mock_invalidation_state_tracker_,
SetMaxVersion(syncable::EXTENSIONS, 2)); SetMaxVersion(syncable::EXTENSIONS, 2));
// Should trigger both. // Should trigger both.
...@@ -217,21 +217,21 @@ TEST_F(ChromeInvalidationClientTest, InvalidateVersionMultipleTypes) { ...@@ -217,21 +217,21 @@ TEST_F(ChromeInvalidationClientTest, InvalidateVersionMultipleTypes) {
FireInvalidate("EXTENSION", 2, NULL); FireInvalidate("EXTENSION", 2, NULL);
Mock::VerifyAndClearExpectations(&mock_listener_); Mock::VerifyAndClearExpectations(&mock_listener_);
Mock::VerifyAndClearExpectations(&mock_invalidation_version_tracker_); Mock::VerifyAndClearExpectations(&mock_invalidation_state_tracker_);
// Should both be dropped. // Should both be dropped.
FireInvalidate("APP", 1, NULL); FireInvalidate("APP", 1, NULL);
FireInvalidate("EXTENSION", 1, NULL); FireInvalidate("EXTENSION", 1, NULL);
Mock::VerifyAndClearExpectations(&mock_listener_); Mock::VerifyAndClearExpectations(&mock_listener_);
Mock::VerifyAndClearExpectations(&mock_invalidation_version_tracker_); Mock::VerifyAndClearExpectations(&mock_invalidation_state_tracker_);
// InvalidateAll shouldn't change any version state. // InvalidateAll shouldn't change any version state.
EXPECT_CALL(mock_listener_, OnInvalidate(MakeMapFromSet(types, ""))); EXPECT_CALL(mock_listener_, OnInvalidate(MakeMapFromSet(types, "")));
FireInvalidateAll(); FireInvalidateAll();
Mock::VerifyAndClearExpectations(&mock_listener_); Mock::VerifyAndClearExpectations(&mock_listener_);
Mock::VerifyAndClearExpectations(&mock_invalidation_version_tracker_); Mock::VerifyAndClearExpectations(&mock_invalidation_state_tracker_);
EXPECT_CALL(mock_listener_, EXPECT_CALL(mock_listener_,
OnInvalidate(MakeMap(syncable::PREFERENCES, ""))); OnInvalidate(MakeMap(syncable::PREFERENCES, "")));
...@@ -240,11 +240,11 @@ TEST_F(ChromeInvalidationClientTest, InvalidateVersionMultipleTypes) { ...@@ -240,11 +240,11 @@ TEST_F(ChromeInvalidationClientTest, InvalidateVersionMultipleTypes) {
EXPECT_CALL(mock_listener_, EXPECT_CALL(mock_listener_,
OnInvalidate(MakeMap(syncable::APPS, ""))); OnInvalidate(MakeMap(syncable::APPS, "")));
EXPECT_CALL(mock_invalidation_version_tracker_, EXPECT_CALL(mock_invalidation_state_tracker_,
SetMaxVersion(syncable::PREFERENCES, 5)); SetMaxVersion(syncable::PREFERENCES, 5));
EXPECT_CALL(mock_invalidation_version_tracker_, EXPECT_CALL(mock_invalidation_state_tracker_,
SetMaxVersion(syncable::EXTENSIONS, 3)); SetMaxVersion(syncable::EXTENSIONS, 3));
EXPECT_CALL(mock_invalidation_version_tracker_, EXPECT_CALL(mock_invalidation_state_tracker_,
SetMaxVersion(syncable::APPS, 4)); SetMaxVersion(syncable::APPS, 4));
// Should trigger all three. // Should trigger all three.
......
...@@ -19,13 +19,13 @@ namespace sync_notifier { ...@@ -19,13 +19,13 @@ namespace sync_notifier {
InvalidationNotifier::InvalidationNotifier( InvalidationNotifier::InvalidationNotifier(
const notifier::NotifierOptions& notifier_options, const notifier::NotifierOptions& notifier_options,
const InvalidationVersionMap& initial_max_invalidation_versions, const InvalidationVersionMap& initial_max_invalidation_versions,
const browser_sync::WeakHandle<InvalidationVersionTracker>& const browser_sync::WeakHandle<InvalidationStateTracker>&
invalidation_version_tracker, invalidation_state_tracker,
const std::string& client_info) const std::string& client_info)
: state_(STOPPED), : state_(STOPPED),
notifier_options_(notifier_options), notifier_options_(notifier_options),
initial_max_invalidation_versions_(initial_max_invalidation_versions), initial_max_invalidation_versions_(initial_max_invalidation_versions),
invalidation_version_tracker_(invalidation_version_tracker), invalidation_state_tracker_(invalidation_state_tracker),
client_info_(client_info) { client_info_(client_info) {
DCHECK_EQ(notifier::NOTIFICATION_SERVER, DCHECK_EQ(notifier::NOTIFICATION_SERVER,
notifier_options.notification_method); notifier_options.notification_method);
...@@ -111,7 +111,7 @@ void InvalidationNotifier::OnConnect( ...@@ -111,7 +111,7 @@ void InvalidationNotifier::OnConnect(
invalidation_client_.Start( invalidation_client_.Start(
invalidation_client_id_, client_info_, invalidation_state_, invalidation_client_id_, client_info_, invalidation_state_,
initial_max_invalidation_versions_, initial_max_invalidation_versions_,
invalidation_version_tracker_, invalidation_state_tracker_,
this, this, base_task); this, this, base_task);
invalidation_state_.clear(); invalidation_state_.clear();
state_ = STARTED; state_ = STARTED;
......
...@@ -23,7 +23,7 @@ ...@@ -23,7 +23,7 @@
#include "jingle/notifier/base/notifier_options.h" #include "jingle/notifier/base/notifier_options.h"
#include "jingle/notifier/communicator/login.h" #include "jingle/notifier/communicator/login.h"
#include "sync/notifier/chrome_invalidation_client.h" #include "sync/notifier/chrome_invalidation_client.h"
#include "sync/notifier/invalidation_version_tracker.h" #include "sync/notifier/invalidation_state_tracker.h"
#include "sync/notifier/state_writer.h" #include "sync/notifier/state_writer.h"
#include "sync/notifier/sync_notifier.h" #include "sync/notifier/sync_notifier.h"
#include "sync/syncable/model_type.h" #include "sync/syncable/model_type.h"
...@@ -38,12 +38,12 @@ class InvalidationNotifier ...@@ -38,12 +38,12 @@ class InvalidationNotifier
public ChromeInvalidationClient::Listener, public ChromeInvalidationClient::Listener,
public StateWriter { public StateWriter {
public: public:
// |invalidation_version_tracker| must be initialized. // |invalidation_state_tracker| must be initialized.
InvalidationNotifier( InvalidationNotifier(
const notifier::NotifierOptions& notifier_options, const notifier::NotifierOptions& notifier_options,
const InvalidationVersionMap& initial_max_invalidation_versions, const InvalidationVersionMap& initial_max_invalidation_versions,
const browser_sync::WeakHandle<InvalidationVersionTracker>& const browser_sync::WeakHandle<InvalidationStateTracker>&
invalidation_version_tracker, invalidation_state_tracker,
const std::string& client_info); const std::string& client_info);
virtual ~InvalidationNotifier(); virtual ~InvalidationNotifier();
...@@ -94,8 +94,8 @@ class InvalidationNotifier ...@@ -94,8 +94,8 @@ class InvalidationNotifier
const InvalidationVersionMap initial_max_invalidation_versions_; const InvalidationVersionMap initial_max_invalidation_versions_;
// Passed to |invalidation_client_|. // Passed to |invalidation_client_|.
const browser_sync::WeakHandle<InvalidationVersionTracker> const browser_sync::WeakHandle<InvalidationStateTracker>
invalidation_version_tracker_; invalidation_state_tracker_;
// Passed to |invalidation_client_|. // Passed to |invalidation_client_|.
const std::string client_info_; const std::string client_info_;
......
...@@ -9,7 +9,7 @@ ...@@ -9,7 +9,7 @@
#include "jingle/notifier/base/fake_base_task.h" #include "jingle/notifier/base/fake_base_task.h"
#include "jingle/notifier/base/notifier_options.h" #include "jingle/notifier/base/notifier_options.h"
#include "net/url_request/url_request_test_util.h" #include "net/url_request/url_request_test_util.h"
#include "sync/notifier/invalidation_version_tracker.h" #include "sync/notifier/invalidation_state_tracker.h"
#include "sync/notifier/mock_sync_notifier_observer.h" #include "sync/notifier/mock_sync_notifier_observer.h"
#include "sync/syncable/model_type.h" #include "sync/syncable/model_type.h"
#include "sync/syncable/model_type_payload_map.h" #include "sync/syncable/model_type_payload_map.h"
...@@ -36,7 +36,7 @@ class InvalidationNotifierTest : public testing::Test { ...@@ -36,7 +36,7 @@ class InvalidationNotifierTest : public testing::Test {
notifier_options, notifier_options,
InvalidationVersionMap(), InvalidationVersionMap(),
browser_sync::MakeWeakHandle( browser_sync::MakeWeakHandle(
base::WeakPtr<InvalidationVersionTracker>()), base::WeakPtr<InvalidationStateTracker>()),
"fake_client_info")); "fake_client_info"));
invalidation_notifier_->AddObserver(&mock_observer_); invalidation_notifier_->AddObserver(&mock_observer_);
} }
......
...@@ -5,8 +5,8 @@ ...@@ -5,8 +5,8 @@
// An InvalidationVersionTracker is an interface that handles getting // An InvalidationVersionTracker is an interface that handles getting
// and setting (persisting) max invalidation versions. // and setting (persisting) max invalidation versions.
#ifndef SYNC_NOTIFIER_INVALIDATION_VERSION_TRACKER_H_ #ifndef SYNC_NOTIFIER_INVALIDATION_STATE_TRACKER_H_
#define SYNC_NOTIFIER_INVALIDATION_VERSION_TRACKER_H_ #define SYNC_NOTIFIER_INVALIDATION_STATE_TRACKER_H_
#include <map> #include <map>
...@@ -17,9 +17,9 @@ namespace sync_notifier { ...@@ -17,9 +17,9 @@ namespace sync_notifier {
typedef std::map<syncable::ModelType, int64> InvalidationVersionMap; typedef std::map<syncable::ModelType, int64> InvalidationVersionMap;
class InvalidationVersionTracker { class InvalidationStateTracker {
public: public:
InvalidationVersionTracker() {} InvalidationStateTracker() {}
virtual InvalidationVersionMap GetAllMaxVersions() const = 0; virtual InvalidationVersionMap GetAllMaxVersions() const = 0;
...@@ -29,10 +29,9 @@ class InvalidationVersionTracker { ...@@ -29,10 +29,9 @@ class InvalidationVersionTracker {
int64 max_version) = 0; int64 max_version) = 0;
protected: protected:
virtual ~InvalidationVersionTracker() {} virtual ~InvalidationStateTracker() {}
}; };
} // namespace sync_notifier } // namespace sync_notifier
#endif // SYNC_NOTIFIER_INVALIDATION_VERSION_TRACKER_H_ #endif // SYNC_NOTIFIER_INVALIDATION_STATE_TRACKER_H_
...@@ -26,8 +26,8 @@ class NonBlockingInvalidationNotifier::Core ...@@ -26,8 +26,8 @@ class NonBlockingInvalidationNotifier::Core
void Initialize( void Initialize(
const notifier::NotifierOptions& notifier_options, const notifier::NotifierOptions& notifier_options,
const InvalidationVersionMap& initial_max_invalidation_versions, const InvalidationVersionMap& initial_max_invalidation_versions,
const browser_sync::WeakHandle<InvalidationVersionTracker>& const browser_sync::WeakHandle<InvalidationStateTracker>&
invalidation_version_tracker, invalidation_state_tracker,
const std::string& client_info); const std::string& client_info);
void Teardown(); void Teardown();
void SetUniqueId(const std::string& unique_id); void SetUniqueId(const std::string& unique_id);
...@@ -69,8 +69,8 @@ NonBlockingInvalidationNotifier::Core::~Core() { ...@@ -69,8 +69,8 @@ NonBlockingInvalidationNotifier::Core::~Core() {
void NonBlockingInvalidationNotifier::Core::Initialize( void NonBlockingInvalidationNotifier::Core::Initialize(
const notifier::NotifierOptions& notifier_options, const notifier::NotifierOptions& notifier_options,
const InvalidationVersionMap& initial_max_invalidation_versions, const InvalidationVersionMap& initial_max_invalidation_versions,
const browser_sync::WeakHandle<InvalidationVersionTracker>& const browser_sync::WeakHandle<InvalidationStateTracker>&
invalidation_version_tracker, invalidation_state_tracker,
const std::string& client_info) { const std::string& client_info) {
DCHECK(notifier_options.request_context_getter); DCHECK(notifier_options.request_context_getter);
DCHECK_EQ(notifier::NOTIFICATION_SERVER, DCHECK_EQ(notifier::NOTIFICATION_SERVER,
...@@ -82,7 +82,7 @@ void NonBlockingInvalidationNotifier::Core::Initialize( ...@@ -82,7 +82,7 @@ void NonBlockingInvalidationNotifier::Core::Initialize(
new InvalidationNotifier( new InvalidationNotifier(
notifier_options, notifier_options,
initial_max_invalidation_versions, initial_max_invalidation_versions,
invalidation_version_tracker, invalidation_state_tracker,
client_info)); client_info));
invalidation_notifier_->AddObserver(this); invalidation_notifier_->AddObserver(this);
} }
...@@ -147,8 +147,8 @@ void NonBlockingInvalidationNotifier::Core::StoreState( ...@@ -147,8 +147,8 @@ void NonBlockingInvalidationNotifier::Core::StoreState(
NonBlockingInvalidationNotifier::NonBlockingInvalidationNotifier( NonBlockingInvalidationNotifier::NonBlockingInvalidationNotifier(
const notifier::NotifierOptions& notifier_options, const notifier::NotifierOptions& notifier_options,
const InvalidationVersionMap& initial_max_invalidation_versions, const InvalidationVersionMap& initial_max_invalidation_versions,
const browser_sync::WeakHandle<InvalidationVersionTracker>& const browser_sync::WeakHandle<InvalidationStateTracker>&
invalidation_version_tracker, invalidation_state_tracker,
const std::string& client_info) const std::string& client_info)
: weak_ptr_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)), : weak_ptr_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)),
core_( core_(
...@@ -165,7 +165,7 @@ NonBlockingInvalidationNotifier::NonBlockingInvalidationNotifier( ...@@ -165,7 +165,7 @@ NonBlockingInvalidationNotifier::NonBlockingInvalidationNotifier(
core_.get(), core_.get(),
notifier_options, notifier_options,
initial_max_invalidation_versions, initial_max_invalidation_versions,
invalidation_version_tracker, invalidation_state_tracker,
client_info))) { client_info))) {
NOTREACHED(); NOTREACHED();
} }
......
...@@ -17,7 +17,7 @@ ...@@ -17,7 +17,7 @@
#include "base/memory/weak_ptr.h" #include "base/memory/weak_ptr.h"
#include "base/observer_list.h" #include "base/observer_list.h"
#include "jingle/notifier/base/notifier_options.h" #include "jingle/notifier/base/notifier_options.h"
#include "sync/notifier/invalidation_version_tracker.h" #include "sync/notifier/invalidation_state_tracker.h"
#include "sync/notifier/sync_notifier.h" #include "sync/notifier/sync_notifier.h"
#include "sync/notifier/sync_notifier_observer.h" #include "sync/notifier/sync_notifier_observer.h"
#include "sync/util/weak_handle.h" #include "sync/util/weak_handle.h"
...@@ -32,12 +32,12 @@ class NonBlockingInvalidationNotifier ...@@ -32,12 +32,12 @@ class NonBlockingInvalidationNotifier
: public SyncNotifier, : public SyncNotifier,
public SyncNotifierObserver { public SyncNotifierObserver {
public: public:
// |invalidation_version_tracker| must be initialized. // |invalidation_state_tracker| must be initialized.
NonBlockingInvalidationNotifier( NonBlockingInvalidationNotifier(
const notifier::NotifierOptions& notifier_options, const notifier::NotifierOptions& notifier_options,
const InvalidationVersionMap& initial_max_invalidation_versions, const InvalidationVersionMap& initial_max_invalidation_versions,
const browser_sync::WeakHandle<InvalidationVersionTracker>& const browser_sync::WeakHandle<InvalidationStateTracker>&
invalidation_version_tracker, invalidation_state_tracker,
const std::string& client_info); const std::string& client_info);
virtual ~NonBlockingInvalidationNotifier(); virtual ~NonBlockingInvalidationNotifier();
......
...@@ -10,7 +10,7 @@ ...@@ -10,7 +10,7 @@
#include "base/threading/thread.h" #include "base/threading/thread.h"
#include "jingle/notifier/base/fake_base_task.h" #include "jingle/notifier/base/fake_base_task.h"
#include "net/url_request/url_request_test_util.h" #include "net/url_request/url_request_test_util.h"
#include "sync/notifier/invalidation_version_tracker.h" #include "sync/notifier/invalidation_state_tracker.h"
#include "sync/notifier/mock_sync_notifier_observer.h" #include "sync/notifier/mock_sync_notifier_observer.h"
#include "sync/syncable/model_type.h" #include "sync/syncable/model_type.h"
#include "sync/syncable/model_type_payload_map.h" #include "sync/syncable/model_type_payload_map.h"
...@@ -43,7 +43,7 @@ class NonBlockingInvalidationNotifierTest : public testing::Test { ...@@ -43,7 +43,7 @@ class NonBlockingInvalidationNotifierTest : public testing::Test {
notifier_options, notifier_options,
InvalidationVersionMap(), InvalidationVersionMap(),
browser_sync::MakeWeakHandle( browser_sync::MakeWeakHandle(
base::WeakPtr<sync_notifier::InvalidationVersionTracker>()), base::WeakPtr<sync_notifier::InvalidationStateTracker>()),
"fake_client_info")); "fake_client_info"));
invalidation_notifier_->AddObserver(&mock_observer_); invalidation_notifier_->AddObserver(&mock_observer_);
} }
......
...@@ -17,8 +17,8 @@ namespace { ...@@ -17,8 +17,8 @@ namespace {
SyncNotifier* CreateDefaultSyncNotifier( SyncNotifier* CreateDefaultSyncNotifier(
const notifier::NotifierOptions& notifier_options, const notifier::NotifierOptions& notifier_options,
const InvalidationVersionMap& initial_max_invalidation_versions, const InvalidationVersionMap& initial_max_invalidation_versions,
const browser_sync::WeakHandle<InvalidationVersionTracker>& const browser_sync::WeakHandle<InvalidationStateTracker>&
invalidation_version_tracker, invalidation_state_tracker,
const std::string& client_info) { const std::string& client_info) {
if (notifier_options.notification_method == notifier::NOTIFICATION_P2P) { if (notifier_options.notification_method == notifier::NOTIFICATION_P2P) {
// TODO(rlarocque): Ideally, the notification target would be // TODO(rlarocque): Ideally, the notification target would be
...@@ -30,7 +30,7 @@ SyncNotifier* CreateDefaultSyncNotifier( ...@@ -30,7 +30,7 @@ SyncNotifier* CreateDefaultSyncNotifier(
return new NonBlockingInvalidationNotifier( return new NonBlockingInvalidationNotifier(
notifier_options, initial_max_invalidation_versions, notifier_options, initial_max_invalidation_versions,
invalidation_version_tracker, client_info); invalidation_state_tracker, client_info);
} }
} // namespace } // namespace
...@@ -39,15 +39,15 @@ SyncNotifier* CreateDefaultSyncNotifier( ...@@ -39,15 +39,15 @@ SyncNotifier* CreateDefaultSyncNotifier(
SyncNotifierFactory::SyncNotifierFactory( SyncNotifierFactory::SyncNotifierFactory(
const notifier::NotifierOptions& notifier_options, const notifier::NotifierOptions& notifier_options,
const std::string& client_info, const std::string& client_info,
const base::WeakPtr<InvalidationVersionTracker>& const base::WeakPtr<InvalidationStateTracker>&
invalidation_version_tracker) invalidation_state_tracker)
: notifier_options_(notifier_options), : notifier_options_(notifier_options),
client_info_(client_info), client_info_(client_info),
initial_max_invalidation_versions_( initial_max_invalidation_versions_(
invalidation_version_tracker.get() ? invalidation_state_tracker.get() ?
invalidation_version_tracker->GetAllMaxVersions() : invalidation_state_tracker->GetAllMaxVersions() :
InvalidationVersionMap()), InvalidationVersionMap()),
invalidation_version_tracker_(invalidation_version_tracker) { invalidation_state_tracker_(invalidation_state_tracker) {
} }
SyncNotifierFactory::~SyncNotifierFactory() { SyncNotifierFactory::~SyncNotifierFactory() {
...@@ -60,7 +60,7 @@ SyncNotifier* SyncNotifierFactory::CreateSyncNotifier() { ...@@ -60,7 +60,7 @@ SyncNotifier* SyncNotifierFactory::CreateSyncNotifier() {
#else #else
return CreateDefaultSyncNotifier(notifier_options_, return CreateDefaultSyncNotifier(notifier_options_,
initial_max_invalidation_versions_, initial_max_invalidation_versions_,
invalidation_version_tracker_, invalidation_state_tracker_,
client_info_); client_info_);
#endif #endif
} }
......
...@@ -9,7 +9,7 @@ ...@@ -9,7 +9,7 @@
#include "base/memory/weak_ptr.h" #include "base/memory/weak_ptr.h"
#include "jingle/notifier/base/notifier_options.h" #include "jingle/notifier/base/notifier_options.h"
#include "sync/notifier/invalidation_version_tracker.h" #include "sync/notifier/invalidation_state_tracker.h"
#include "sync/util/weak_handle.h" #include "sync/util/weak_handle.h"
namespace sync_notifier { namespace sync_notifier {
...@@ -21,13 +21,13 @@ class SyncNotifier; ...@@ -21,13 +21,13 @@ class SyncNotifier;
class SyncNotifierFactory { class SyncNotifierFactory {
public: public:
// |client_info| is a string identifying the client, e.g. a user // |client_info| is a string identifying the client, e.g. a user
// agent string. |invalidation_version_tracker| may be NULL (for // agent string. |invalidation_state_tracker| may be NULL (for
// tests). // tests).
SyncNotifierFactory( SyncNotifierFactory(
const notifier::NotifierOptions& notifier_options, const notifier::NotifierOptions& notifier_options,
const std::string& client_info, const std::string& client_info,
const base::WeakPtr<InvalidationVersionTracker>& const base::WeakPtr<InvalidationStateTracker>&
invalidation_version_tracker); invalidation_state_tracker);
~SyncNotifierFactory(); ~SyncNotifierFactory();
// Creates a sync notifier. Caller takes ownership of the returned // Creates a sync notifier. Caller takes ownership of the returned
...@@ -39,8 +39,8 @@ class SyncNotifierFactory { ...@@ -39,8 +39,8 @@ class SyncNotifierFactory {
const notifier::NotifierOptions notifier_options_; const notifier::NotifierOptions notifier_options_;
const std::string client_info_; const std::string client_info_;
const InvalidationVersionMap initial_max_invalidation_versions_; const InvalidationVersionMap initial_max_invalidation_versions_;
const browser_sync::WeakHandle<InvalidationVersionTracker> const browser_sync::WeakHandle<InvalidationStateTracker>
invalidation_version_tracker_; invalidation_state_tracker_;
}; };
} // namespace sync_notifier } // namespace sync_notifier
......
...@@ -14,7 +14,7 @@ ...@@ -14,7 +14,7 @@
#include "jingle/notifier/base/notification_method.h" #include "jingle/notifier/base/notification_method.h"
#include "jingle/notifier/base/notifier_options.h" #include "jingle/notifier/base/notifier_options.h"
#include "net/url_request/url_request_test_util.h" #include "net/url_request/url_request_test_util.h"
#include "sync/notifier/invalidation_version_tracker.h" #include "sync/notifier/invalidation_state_tracker.h"
#include "sync/notifier/mock_sync_notifier_observer.h" #include "sync/notifier/mock_sync_notifier_observer.h"
#include "sync/notifier/sync_notifier.h" #include "sync/notifier/sync_notifier.h"
#include "sync/syncable/model_type.h" #include "sync/syncable/model_type.h"
...@@ -54,7 +54,7 @@ TEST_F(SyncNotifierFactoryTest, Basic) { ...@@ -54,7 +54,7 @@ TEST_F(SyncNotifierFactoryTest, Basic) {
SyncNotifierFactory factory( SyncNotifierFactory factory(
notifier_options_, notifier_options_,
"test client info", "test client info",
base::WeakPtr<sync_notifier::InvalidationVersionTracker>()); base::WeakPtr<sync_notifier::InvalidationStateTracker>());
scoped_ptr<SyncNotifier> notifier(factory.CreateSyncNotifier()); scoped_ptr<SyncNotifier> notifier(factory.CreateSyncNotifier());
#if defined(OS_ANDROID) #if defined(OS_ANDROID)
ASSERT_FALSE(notifier.get()); ASSERT_FALSE(notifier.get());
...@@ -71,7 +71,7 @@ TEST_F(SyncNotifierFactoryTest, Basic_P2P) { ...@@ -71,7 +71,7 @@ TEST_F(SyncNotifierFactoryTest, Basic_P2P) {
SyncNotifierFactory factory( SyncNotifierFactory factory(
notifier_options_, notifier_options_,
"test client info", "test client info",
base::WeakPtr<sync_notifier::InvalidationVersionTracker>()); base::WeakPtr<sync_notifier::InvalidationStateTracker>());
scoped_ptr<SyncNotifier> notifier(factory.CreateSyncNotifier()); scoped_ptr<SyncNotifier> notifier(factory.CreateSyncNotifier());
#if defined(OS_ANDROID) #if defined(OS_ANDROID)
ASSERT_FALSE(notifier.get()); ASSERT_FALSE(notifier.get());
......
...@@ -223,7 +223,7 @@ ...@@ -223,7 +223,7 @@
'notifier/invalidation_notifier.cc', 'notifier/invalidation_notifier.cc',
'notifier/invalidation_util.cc', 'notifier/invalidation_util.cc',
'notifier/invalidation_util.h', 'notifier/invalidation_util.h',
'notifier/invalidation_version_tracker.h', 'notifier/invalidation_state_tracker.h',
'notifier/non_blocking_invalidation_notifier.h', 'notifier/non_blocking_invalidation_notifier.h',
'notifier/non_blocking_invalidation_notifier.cc', 'notifier/non_blocking_invalidation_notifier.cc',
'notifier/p2p_notifier.h', 'notifier/p2p_notifier.h',
......
...@@ -19,7 +19,7 @@ ...@@ -19,7 +19,7 @@
#include "jingle/notifier/base/notifier_options.h" #include "jingle/notifier/base/notifier_options.h"
#include "net/base/host_port_pair.h" #include "net/base/host_port_pair.h"
#include "net/url_request/url_request_test_util.h" #include "net/url_request/url_request_test_util.h"
#include "sync/notifier/invalidation_version_tracker.h" #include "sync/notifier/invalidation_state_tracker.h"
#include "sync/notifier/sync_notifier.h" #include "sync/notifier/sync_notifier.h"
#include "sync/notifier/sync_notifier_factory.h" #include "sync/notifier/sync_notifier_factory.h"
#include "sync/notifier/sync_notifier_observer.h" #include "sync/notifier/sync_notifier_observer.h"
...@@ -65,12 +65,12 @@ class NotificationPrinter : public sync_notifier::SyncNotifierObserver { ...@@ -65,12 +65,12 @@ class NotificationPrinter : public sync_notifier::SyncNotifierObserver {
DISALLOW_COPY_AND_ASSIGN(NotificationPrinter); DISALLOW_COPY_AND_ASSIGN(NotificationPrinter);
}; };
class NullInvalidationVersionTracker class NullInvalidationStateTracker
: public base::SupportsWeakPtr<NullInvalidationVersionTracker>, : public base::SupportsWeakPtr<NullInvalidationStateTracker>,
public sync_notifier::InvalidationVersionTracker { public sync_notifier::InvalidationStateTracker {
public: public:
NullInvalidationVersionTracker() {} NullInvalidationStateTracker() {}
virtual ~NullInvalidationVersionTracker() {} virtual ~NullInvalidationStateTracker() {}
virtual sync_notifier::InvalidationVersionMap virtual sync_notifier::InvalidationVersionMap
GetAllMaxVersions() const OVERRIDE { GetAllMaxVersions() const OVERRIDE {
...@@ -171,10 +171,10 @@ int main(int argc, char* argv[]) { ...@@ -171,10 +171,10 @@ int main(int argc, char* argv[]) {
command_line, command_line,
new TestURLRequestContextGetter(io_thread.message_loop_proxy())); new TestURLRequestContextGetter(io_thread.message_loop_proxy()));
const char kClientInfo[] = "sync_listen_notifications"; const char kClientInfo[] = "sync_listen_notifications";
NullInvalidationVersionTracker null_invalidation_version_tracker; NullInvalidationStateTracker null_invalidation_state_tracker;
sync_notifier::SyncNotifierFactory sync_notifier_factory( sync_notifier::SyncNotifierFactory sync_notifier_factory(
notifier_options, kClientInfo, notifier_options, kClientInfo,
null_invalidation_version_tracker.AsWeakPtr()); null_invalidation_state_tracker.AsWeakPtr());
scoped_ptr<sync_notifier::SyncNotifier> sync_notifier( scoped_ptr<sync_notifier::SyncNotifier> sync_notifier(
sync_notifier_factory.CreateSyncNotifier()); sync_notifier_factory.CreateSyncNotifier());
NotificationPrinter notification_printer; NotificationPrinter notification_printer;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment