| /external/chromium_org/sync/internal_api/public/base/ |
| invalidation_test_util.h | 15 class Invalidation;
20 void PrintTo(const Invalidation& invalidation, ::std::ostream* os);
22 ::testing::Matcher<const Invalidation&> Eq(const Invalidation& expected);
|
| invalidation.cc | 5 #include "sync/internal_api/public/base/invalidation.h"
27 Invalidation Invalidation::Init(
28 const invalidation::ObjectId& id,
31 return Invalidation(id, false, version, payload, AckHandle::CreateUnique());
34 Invalidation Invalidation::InitUnknownVersion(
35 const invalidation::ObjectId& id) {
36 return Invalidation(id, true, kInvalidVersion,
40 Invalidation Invalidation::InitFromDroppedInvalidation
[all...] |
| invalidation.h | 23 // Represents a local invalidation, and is roughly analogous to
24 // invalidation::Invalidation. Unlike invalidation::Invalidation, this class
26 class SYNC_EXPORT Invalidation {
29 static Invalidation Init(
30 const invalidation::ObjectId& id,
33 static Invalidation InitUnknownVersion(const invalidation::ObjectId& id)
[all...] |
| invalidation_test_util.cc | 11 #include "sync/internal_api/public/base/invalidation.h"
57 : public MatcherInterface<const Invalidation&> {
59 explicit InvalidationEqMatcher(const Invalidation& expected);
61 virtual bool MatchAndExplain(const Invalidation& actual,
67 const Invalidation expected_;
73 const Invalidation& expected) : expected_(expected) {
77 const Invalidation& actual, MatchResultListener* listener) const {
113 void PrintTo(const Invalidation& inv, ::std::ostream* os) {
117 Matcher<const Invalidation&> Eq(const Invalidation& expected)
[all...] |
| object_id_invalidation_map_test_util.cc | 45 InvalidationEqPredicate(const Invalidation& inv1)
48 bool operator()(const Invalidation& inv2) {
52 const Invalidation& inv1_;
61 std::vector<syncer::Invalidation> expected_invalidations;
62 std::vector<syncer::Invalidation> actual_invalidations;
67 std::vector<syncer::Invalidation> expected_only;
68 std::vector<syncer::Invalidation> actual_only;
70 for (std::vector<syncer::Invalidation>::iterator it =
81 for (std::vector<syncer::Invalidation>::iterator it =
|
| model_type_test_util.h | 16 // Builds an invaliation map that contains a single invalidation with specified
24 // Builds an invalidation. Similar to Invalidation::Init, but its first
26 syncer::Invalidation BuildInvalidation(
|
| model_type_test_util.cc | 10 syncer::Invalidation BuildInvalidation(
14 invalidation::ObjectId id;
17 return Invalidation::Init(id, version, payload);
|
| /external/chromium_org/sync/notifier/ |
| mock_ack_handler.h | 20 class Invalidation;
31 // Sets up some internal state to track this invalidation, and modifies it so
33 void RegisterInvalidation(Invalidation* invalidation);
35 // No one was listening for this invalidation, so no one will receive it or
37 void RegisterUnsentInvalidation(Invalidation* invalidation);
41 bool IsUnacked(const Invalidation& invalidation) const;
43 // Returns true if the specified invalidation has been delivered an
[all...] |
| unacked_invalidation_set_unittest.cc | 32 const invalidation::ObjectId kObjectId_;
43 // Test storage and retrieval of a single invalidation.
45 Invalidation inv1 = Invalidation::Init(kObjectId_, 10, "payload");
55 Invalidation inv1 = Invalidation::Init(kObjectId_, 10, "payload");
64 Invalidation inv1 = Invalidation::Init(kObjectId_, 10, "payload");
65 Invalidation inv2 = Invalidation::InitUnknownVersion(kObjectId_)
[all...] |
| single_object_invalidation_set_unittest.cc | 18 : kId(ipc::invalidation::ObjectSource::TEST, "one") {
21 const invalidation::ObjectId kId;
28 Invalidation inv0 = Invalidation::InitUnknownVersion(kId);
29 Invalidation inv1 = Invalidation::Init(kId, 1, "one");
30 Invalidation inv2 = Invalidation::Init(kId, 5, "five");
65 list.Insert(Invalidation::Init(kId, 1, "one"));
68 list.Insert(Invalidation::InitUnknownVersion(kId))
[all...] |
| invalidation_util.h | 5 // Various utilities for dealing with invalidation data types.
23 namespace invalidation { namespace
25 class Invalidation;
29 SYNC_EXPORT_PRIVATE void PrintTo(const invalidation::ObjectId& id,
32 } // namespace invalidation
36 class Invalidation;
39 bool operator()(const invalidation::ObjectId& lhs,
40 const invalidation::ObjectId& rhs) const;
44 bool operator()(const syncer::Invalidation& a,
45 const syncer::Invalidation& b) const
[all...] |
| single_object_invalidation_set.h | 12 #include "sync/internal_api/public/base/invalidation.h"
24 // operations, like checking for an unknown version invalidation or fetching the
25 // highest invalidation with the highest version number.
28 typedef std::set<Invalidation, InvalidationVersionLessThan> InvalidationsSet;
35 void Insert(const Invalidation& invalidation);
53 const Invalidation& back() const;
|
| single_object_invalidation_set.cc | 16 void SingleObjectInvalidationSet::Insert(const Invalidation& invalidation) {
17 invalidations_.insert(invalidation);
49 bool operator()(const Invalidation& inv1, const Invalidation& inv2) {
84 const Invalidation& SingleObjectInvalidationSet::back() const {
102 DLOG(WARNING) << "Could not find invalidation at index " << i;
105 scoped_ptr<Invalidation> invalidation = Invalidation::InitFromValue(*dict) local
[all...] |
| mock_ack_handler.cc | 8 #include "sync/internal_api/public/base/invalidation.h"
16 bool operator()(const syncer::Invalidation& invalidation) const;
25 const syncer::Invalidation& invalidation) const {
26 return handle_.Equals(invalidation.ack_handle());
35 void MockAckHandler::RegisterInvalidation(Invalidation* invalidation) {
36 unacked_invalidations_.push_back(*invalidation);
37 invalidation->set_ack_handler(WeakHandleThis())
[all...] |
| dropped_invalidation_tracker.h | 16 class Invalidation;
23 // invalidation handler that intends to buffer and occasionally drop
26 // When an invalidation handler wishes to drop an invalidation, it must provide
27 // an instance of this class to that Invalidation's Drop() method. In order to
35 explicit DroppedInvalidationTracker(const invalidation::ObjectId& id);
38 const invalidation::ObjectId& object_id() const;
40 // Called by Invalidation::Drop() to keep track of a drop event.
43 // dropped invalidation. See also the comment for this class'
54 invalidation::ObjectId id_
[all...] |
| object_id_invalidation_map.h | 12 #include "sync/internal_api/public/base/invalidation.h"
22 // Creates an invalidation map that includes an 'unknown version'
23 // invalidation for each specified ID in |ids|.
29 // Returns set of ObjectIds for which at least one invalidation is present.
38 // Inserts a new invalidation into this map.
39 void Insert(const Invalidation& invalidation);
47 invalidation::ObjectId id) const;
50 void GetAllInvalidations(std::vector<syncer::Invalidation>* out) const;
65 typedef std::map<invalidation::ObjectId
[all...] |
| unacked_invalidation_set.cc | 15 const char kInvalidationListKey[] = "invalidation-list";
25 invalidation::ObjectId id)
38 const invalidation::ObjectId& UnackedInvalidationSet::object_id() const {
43 const Invalidation& invalidation) {
45 set.Insert(invalidation);
63 // Copy the invalidation and set the copy's ack_handler.
64 Invalidation inv(*it);
99 // Erase the invalidation with matching ack handle from the list. Also creates
100 // an 'UnknownVersion' invalidation with the same ack handle and places it a
178 scoped_ptr<Invalidation> invalidation = Invalidation::InitFromValue(*dict); local
[all...] |
| unacked_invalidation_set.h | 11 #include "sync/internal_api/public/base/invalidation.h"
36 UnackedInvalidationSet(invalidation::ObjectId id);
41 const invalidation::ObjectId& object_id() const;
43 // Adds a new invalidation to the set awaiting acknowledgement.
44 void Add(const Invalidation& invalidation);
82 // the invalidation and drops it from the list. It is considered to be
87 // the invalidation, drops it from the list, and adds additional state to
88 // indicate that this invalidation has been lost without being acted on.
98 typedef std::set<Invalidation, InvalidationVersionLessThan> InvalidationsSet
[all...] |
| object_id_invalidation_map.cc | 16 invalidate_all.Insert(Invalidation::InitUnknownVersion(*it));
37 void ObjectIdInvalidationMap::Insert(const Invalidation& invalidation) {
38 map_[invalidation.object_id()].Insert(invalidation);
54 invalidation::ObjectId id) const {
62 std::vector<syncer::Invalidation>* out) const {
101 scoped_ptr<Invalidation> invalidation = Invalidation::InitFromValue(*dict) local
[all...] |
| /external/chromium_org/chrome/browser/invalidation/ |
| invalidator_storage_unittest.cc | 5 #include "components/invalidation/invalidator_storage.h"
14 namespace invalidation { namespace
80 syncer::Invalidation unknown_version_inv =
81 syncer::Invalidation::InitUnknownVersion(id1);
82 syncer::Invalidation known_version_inv =
83 syncer::Invalidation::Init(id1, 314, "payload");
89 syncer::Invalidation obj2_inv =
90 syncer::Invalidation::Init(id2, 1234, "payl\0ad\xff");
104 } // namespace invalidation
|
| fake_invalidation_service.h | 14 #include "components/invalidation/invalidation_service.h"
15 #include "components/invalidation/invalidator_registrar.h"
20 class Invalidation;
23 namespace invalidation { namespace
55 void EmitInvalidationForTest(const syncer::Invalidation& invalidation);
71 } // namespace invalidation
|
| fake_invalidation_service.cc | 5 #include "chrome/browser/invalidation/fake_invalidation_service.h"
8 #include "components/invalidation/invalidation_service_util.h"
11 namespace invalidation { namespace
67 const syncer::Invalidation& invalidation) {
70 syncer::Invalidation invalidation_copy(invalidation);
72 // If no one is listening to this invalidation, do not send it out.
75 if (registered_ids.find(invalidation.object_id()) == registered_ids.end()) {
80 // Otherwise, register the invalidation with the mock_ack_handler_ and delive
[all...] |
| /external/chromium_org/components/invalidation/ |
| invalidation_service_test_template.h | 76 #include "components/invalidation/fake_invalidation_handler.h"
77 #include "components/invalidation/invalidation_service.h"
81 #include "sync/internal_api/public/base/invalidation.h"
90 : id1(ipc::invalidation::ObjectSource::CHROME_SYNC, "BOOKMARK"),
91 id2(ipc::invalidation::ObjectSource::CHROME_SYNC, "PREFERENCE"),
92 id3(ipc::invalidation::ObjectSource::CHROME_SYNC, "AUTOFILL"),
93 id4(ipc::invalidation::ObjectSource::CHROME_PUSH_MESSAGING,
97 invalidation::InvalidationService*
105 const invalidation::ObjectId id1;
106 const invalidation::ObjectId id2
[all...] |
| invalidator_test_template.h | 82 #include "components/invalidation/fake_invalidation_handler.h"
83 #include "components/invalidation/fake_invalidation_state_tracker.h"
96 : id1(ipc::invalidation::ObjectSource::TEST, "a"),
97 id2(ipc::invalidation::ObjectSource::TEST, "b"),
98 id3(ipc::invalidation::ObjectSource::TEST, "c"),
99 id4(ipc::invalidation::ObjectSource::TEST, "d") {
118 const invalidation::ObjectId id1;
119 const invalidation::ObjectId id2;
120 const invalidation::ObjectId id3;
121 const invalidation::ObjectId id4
[all...] |
| /external/chromium_org/chrome/browser/extensions/api/push_messaging/ |
| push_messaging_invalidation_handler_unittest.cc | 10 #include "components/invalidation/invalidation_logger.h"
11 #include "components/invalidation/invalidation_service.h"
26 class MockInvalidationService : public invalidation::InvalidationService {
38 MOCK_METHOD0(GetInvalidationLogger, invalidation::InvalidationLogger*());
88 expected_ids.insert(invalidation::ObjectId(
89 ipc::invalidation::ObjectSource::CHROME_PUSH_MESSAGING,
91 expected_ids.insert(invalidation::ObjectId(
92 ipc::invalidation::ObjectSource::CHROME_PUSH_MESSAGING,
94 expected_ids.insert(invalidation::ObjectId(
95 ipc::invalidation::ObjectSource::CHROME_PUSH_MESSAGING
[all...] |
