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 |