| Index: sync/notifier/fake_invalidation_state_tracker.cc
|
| diff --git a/sync/notifier/fake_invalidation_state_tracker.cc b/sync/notifier/fake_invalidation_state_tracker.cc
|
| index 9073e45b1dff6e7fd200fa713c5efc96288a8f5d..2af5db563da5e51ef046774be095b351ec0a3e24 100644
|
| --- a/sync/notifier/fake_invalidation_state_tracker.cc
|
| +++ b/sync/notifier/fake_invalidation_state_tracker.cc
|
| @@ -4,6 +4,10 @@
|
|
|
| #include "sync/notifier/fake_invalidation_state_tracker.h"
|
|
|
| +#include "base/bind.h"
|
| +#include "base/callback.h"
|
| +#include "base/location.h"
|
| +#include "base/task_runner.h"
|
| #include "testing/gtest/include/gtest/gtest.h"
|
|
|
| namespace syncer {
|
| @@ -25,8 +29,10 @@ FakeInvalidationStateTracker::GetAllInvalidationStates() const {
|
| return state_map_;
|
| }
|
|
|
| -void FakeInvalidationStateTracker::SetMaxVersion(
|
| - const invalidation::ObjectId& id, int64 max_version) {
|
| +void FakeInvalidationStateTracker::SetMaxVersionAndPayload(
|
| + const invalidation::ObjectId& id,
|
| + int64 max_version,
|
| + const std::string& payload) {
|
| InvalidationStateMap::const_iterator it = state_map_.find(id);
|
| if ((it != state_map_.end()) && (max_version <= it->second.version)) {
|
| ADD_FAILURE();
|
| @@ -50,4 +56,25 @@ std::string FakeInvalidationStateTracker::GetBootstrapData() const {
|
| return bootstrap_data_;
|
| }
|
|
|
| +void FakeInvalidationStateTracker::GenerateAckHandles(
|
| + const ObjectIdSet& ids,
|
| + const scoped_refptr<base::TaskRunner>& task_runner,
|
| + base::Callback<void(const AckHandleMap&)> callback) {
|
| + AckHandleMap ack_handles;
|
| + for (ObjectIdSet::const_iterator it = ids.begin(); it != ids.end(); ++it) {
|
| + state_map_[*it].expected = AckHandle::CreateUnique();
|
| + ack_handles.insert(std::make_pair(*it, state_map_[*it].expected));
|
| + }
|
| + if (!task_runner->PostTask(FROM_HERE, base::Bind(callback, ack_handles)))
|
| + ADD_FAILURE();
|
| +}
|
| +
|
| +void FakeInvalidationStateTracker::Acknowledge(const invalidation::ObjectId& id,
|
| + const AckHandle& ack_handle) {
|
| + InvalidationStateMap::iterator it = state_map_.find(id);
|
| + if (it == state_map_.end())
|
| + ADD_FAILURE();
|
| + it->second.current = ack_handle;
|
| +}
|
| +
|
| } // namespace syncer
|
|
|