| /external/chromium_org/sync/notifier/ |
| D | sync_invalidation_listener.h | 46 : public NON_EXPORTED_BASE(invalidation::InvalidationListener), in NON_EXPORTED_BASE()
52 typedef base::Callback<invalidation::InvalidationClient*( in NON_EXPORTED_BASE()
53 invalidation::SystemResources*, in NON_EXPORTED_BASE()
55 const invalidation::string&, in NON_EXPORTED_BASE()
56 const invalidation::string&, in NON_EXPORTED_BASE()
57 invalidation::InvalidationListener*)> CreateInvalidationClientCallback; in NON_EXPORTED_BASE()
94 invalidation::InvalidationClient* client) OVERRIDE; in NON_EXPORTED_BASE()
96 invalidation::InvalidationClient* client, in NON_EXPORTED_BASE()
97 const invalidation::Invalidation& invalidation, in NON_EXPORTED_BASE()
98 const invalidation::AckHandle& ack_handle) OVERRIDE; in NON_EXPORTED_BASE()
[all …]
|
| D | sync_system_resources.h | 28 class SyncLogger : public invalidation::Logger {
39 invalidation::SystemResources* resources) OVERRIDE;
42 class SyncInvalidationScheduler : public invalidation::Scheduler {
53 virtual void Schedule(invalidation::TimeDelta delay,
54 invalidation::Closure* task) OVERRIDE;
58 virtual invalidation::Time GetCurrentTime() const OVERRIDE;
61 invalidation::SystemResources* resources) OVERRIDE;
65 void RunPostedTask(invalidation::Closure* task);
68 std::set<invalidation::Closure*> posted_tasks_;
85 : public NON_EXPORTED_BASE(invalidation::NetworkChannel) { in NON_EXPORTED_BASE()
[all …]
|
| D | mock_ack_handler.cc | 16 bool operator()(const syncer::Invalidation& invalidation) const;
25 const syncer::Invalidation& invalidation) const { in operator ()()
26 return handle_.Equals(invalidation.ack_handle()); in operator ()()
35 void MockAckHandler::RegisterInvalidation(Invalidation* invalidation) { in RegisterInvalidation() argument
36 unacked_invalidations_.push_back(*invalidation); in RegisterInvalidation()
37 invalidation->set_ack_handler(WeakHandleThis()); in RegisterInvalidation()
40 void MockAckHandler::RegisterUnsentInvalidation(Invalidation* invalidation) { in RegisterUnsentInvalidation() argument
41 unsent_invalidations_.push_back(*invalidation); in RegisterUnsentInvalidation()
44 bool MockAckHandler::IsUnacked(const Invalidation& invalidation) const { in IsUnacked()
45 AckHandleMatcher matcher(invalidation.ack_handle()); in IsUnacked()
[all …]
|
| D | invalidation_util.h | 22 namespace invalidation {
28 SYNC_EXPORT_PRIVATE void PrintTo(const invalidation::ObjectId& id,
38 bool operator()(const invalidation::ObjectId& lhs,
39 const invalidation::ObjectId& rhs) const;
47 typedef std::set<invalidation::ObjectId, ObjectIdLessThan> ObjectIdSet;
50 invalidation::ObjectId* object_id);
52 bool ObjectIdToRealModelType(const invalidation::ObjectId& object_id,
57 const invalidation::ObjectId& object_id);
60 invalidation::ObjectId* out);
63 const invalidation::ObjectId& object_id);
[all …]
|
| D | invalidation_util.cc | 17 namespace invalidation { namespace
18 void PrintTo(const invalidation::ObjectId& id, std::ostream* os) { in PrintTo()
25 bool ObjectIdLessThan::operator()(const invalidation::ObjectId& lhs, in operator ()()
26 const invalidation::ObjectId& rhs) const { in operator ()()
51 invalidation::ObjectId* object_id) { in RealModelTypeToObjectId()
56 object_id->Init(ipc::invalidation::ObjectSource::CHROME_SYNC, in RealModelTypeToObjectId()
61 bool ObjectIdToRealModelType(const invalidation::ObjectId& object_id, in ObjectIdToRealModelType()
67 const invalidation::ObjectId& object_id) { in ObjectIdToValue()
75 invalidation::ObjectId* out) { in ObjectIdFromValue()
76 *out = invalidation::ObjectId(); in ObjectIdFromValue()
[all …]
|
| D | registration_manager.h | 25 using ::invalidation::InvalidationListener;
60 typedef std::map<invalidation::ObjectId,
67 invalidation::InvalidationClient* invalidation_client);
78 void MarkRegistrationLost(const invalidation::ObjectId& id);
85 void DisableId(const invalidation::ObjectId& id);
113 RegistrationStatus(const invalidation::ObjectId& id,
126 const invalidation::ObjectId id;
150 typedef std::map<invalidation::ObjectId,
160 void TryRegisterId(const invalidation::ObjectId& id,
167 void DoRegisterId(const invalidation::ObjectId& id);
[all …]
|
| D | sync_invalidation_listener.cc | 80 int client_type = ipc::invalidation::ClientType::CHROME_SYNC_IOS; in Start()
82 int client_type = ipc::invalidation::ClientType::CHROME_SYNC; in Start()
112 invalidation::InvalidationClient* client) { in Ready()
121 invalidation::InvalidationClient* client, in Invalidate()
122 const invalidation::Invalidation& invalidation, in Invalidate() argument
123 const invalidation::AckHandle& ack_handle) { in Invalidate()
128 const invalidation::ObjectId& id = invalidation.object_id(); in Invalidate()
132 if (invalidation.has_payload()) in Invalidate()
133 payload = invalidation.payload(); in Invalidate()
135 DVLOG(2) << "Received invalidation with version " << invalidation.version() in Invalidate()
[all …]
|
| D | sync_system_resources.cc | 59 void SyncLogger::SetSystemResources(invalidation::SystemResources* resources) { in SetSystemResources()
93 void SyncInvalidationScheduler::Schedule(invalidation::TimeDelta delay, in Schedule()
94 invalidation::Closure* task) { in Schedule()
95 DCHECK(invalidation::IsCallbackRepeatable(task)); in Schedule()
114 invalidation::Time SyncInvalidationScheduler::GetCurrentTime() const { in GetCurrentTime()
120 invalidation::SystemResources* resources) { in SetSystemResources()
124 void SyncInvalidationScheduler::RunPostedTask(invalidation::Closure* task) { in RunPostedTask()
148 invalidation::MessageCallback* incoming_receiver) { in SetMessageReceiver()
153 invalidation::NetworkStatusCallback* network_status_receiver) { in AddNetworkStatusReceiver()
159 invalidation::SystemResources* resources) { in SetSystemResources()
[all …]
|
| D | mock_ack_handler.h | 31 void RegisterInvalidation(Invalidation* invalidation);
35 void RegisterUnsentInvalidation(Invalidation* invalidation);
39 bool IsUnacked(const Invalidation& invalidation) const;
42 bool IsUnsent(const Invalidation& invalidation) const;
46 const invalidation::ObjectId& id,
49 const invalidation::ObjectId& id,
|
| D | registration_manager.cc | 24 const invalidation::ObjectId& id, RegistrationManager* manager) in RegistrationStatus()
28 state(invalidation::InvalidationListener::UNREGISTERED) { in RegistrationStatus()
46 state = invalidation::InvalidationListener::UNREGISTERED; in Disable()
59 invalidation::InvalidationClient* invalidation_client) in RegistrationManager()
100 const invalidation::ObjectId& id) { in MarkRegistrationLost()
111 it->second->state = invalidation::InvalidationListener::UNREGISTERED; in MarkRegistrationLost()
127 void RegistrationManager::DisableId(const invalidation::ObjectId& id) { in DisableId()
168 const invalidation::ObjectId& id = it->first; in GetPendingRegistrationsForTest()
202 void RegistrationManager::TryRegisterId(const invalidation::ObjectId& id, in TryRegisterId()
256 void RegistrationManager::DoRegisterId(const invalidation::ObjectId& id) { in DoRegisterId()
[all …]
|
| D | sync_system_resources_unittest.cc | 43 MOCK_CONST_METHOD1(Run, void(invalidation::Status));
44 base::Callback<void(invalidation::Status)>* CreateCallback() { in CreateCallback()
45 return new base::Callback<void(invalidation::Status)>( in CreateCallback()
66 invalidation::Scheduler::NoDelay(), should_not_run); in ScheduleShouldNotRun()
74 invalidation::Scheduler::NoDelay(), should_not_run); in ScheduleShouldNotRun()
82 invalidation::TimeDelta::FromSeconds(0), should_not_run); in ScheduleShouldNotRun()
98 invalidation::Time current_time = in TEST_F()
137 invalidation::Scheduler::NoDelay(), mock_closure.CreateClosure()); in TEST_F()
146 invalidation::Scheduler::NoDelay(), mock_closure.CreateClosure()); in TEST_F()
157 invalidation::TimeDelta::FromSeconds(0), mock_closure.CreateClosure()); in TEST_F()
[all …]
|
| D | unacked_invalidation_set.cc | 26 invalidation::ObjectId id) in UnackedInvalidationSet()
32 const invalidation::ObjectId& UnackedInvalidationSet::object_id() const { in object_id()
37 const Invalidation& invalidation) { in Add() argument
39 set.Insert(invalidation); in Add()
153 object_id_ = invalidation::ObjectId(source, name); in ResetFromValue()
172 scoped_ptr<Invalidation> invalidation = Invalidation::InitFromValue(*dict); in ResetListFromValue() local
173 if (!invalidation) { in ResetListFromValue()
177 invalidations_.insert(*invalidation.get()); in ResetListFromValue()
197 invalidation::ObjectId id = invalidations_.begin()->object_id(); in Truncate()
|
| D | unacked_invalidation_set.h | 36 UnackedInvalidationSet(invalidation::ObjectId id);
40 const invalidation::ObjectId& object_id() const;
43 void Add(const Invalidation& invalidation);
107 invalidation::ObjectId object_id_;
111 typedef std::map<invalidation::ObjectId,
|
| /external/chromium_org/chrome/browser/extensions/api/push_messaging/ |
| D | push_messaging_invalidation_handler_unittest.cc | 25 class MockInvalidationService : public invalidation::InvalidationService {
83 expected_ids.insert(invalidation::ObjectId( in TEST_F()
84 ipc::invalidation::ObjectSource::CHROME_PUSH_MESSAGING, in TEST_F()
86 expected_ids.insert(invalidation::ObjectId( in TEST_F()
87 ipc::invalidation::ObjectSource::CHROME_PUSH_MESSAGING, in TEST_F()
89 expected_ids.insert(invalidation::ObjectId( in TEST_F()
90 ipc::invalidation::ObjectSource::CHROME_PUSH_MESSAGING, in TEST_F()
92 expected_ids.insert(invalidation::ObjectId( in TEST_F()
93 ipc::invalidation::ObjectSource::CHROME_PUSH_MESSAGING, in TEST_F()
109 invalidation::ObjectId( in TEST_F()
[all …]
|
| /external/chromium/chrome/browser/sync/notifier/ |
| D | chrome_invalidation_client.cc | 56 invalidation::ClientType client_type; in Start()
57 client_type.set_type(invalidation::ClientType::CHROME_SYNC); in Start()
60 invalidation::ClientConfig client_config; in Start()
66 new invalidation::InvalidationClientImpl( in Start()
70 invalidation::NetworkEndpoint* network_endpoint = in Start()
117 const invalidation::Invalidation& invalidation, in Invalidate() argument
118 invalidation::Closure* callback) { in Invalidate()
120 DCHECK(invalidation::IsCallbackRepeatable(callback)); in Invalidate()
121 VLOG(1) << "Invalidate: " << InvalidationToString(invalidation); in Invalidate()
123 if (!ObjectIdToRealModelType(invalidation.object_id(), &model_type)) { in Invalidate()
[all …]
|
| D | invalidation_util.cc | 11 void RunAndDeleteClosure(invalidation::Closure* task) { in RunAndDeleteClosure()
17 invalidation::ObjectId* object_id) { in RealModelTypeToObjectId()
23 object_id->Init(invalidation::ObjectSource::CHROME_SYNC, notification_type); in RealModelTypeToObjectId()
27 bool ObjectIdToRealModelType(const invalidation::ObjectId& object_id, in ObjectIdToRealModelType()
35 const invalidation::ObjectId& object_id) { in ObjectIdToString()
45 const invalidation::ObjectIdP& object_id) { in ObjectIdPToString()
47 invalidation::ObjectId( in ObjectIdPToString()
48 (invalidation::ObjectSource_Type) object_id.source(), in ObjectIdPToString()
53 const invalidation::Status& status) { in StatusToString()
63 const invalidation::Invalidation& invalidation) { in InvalidationToString() argument
[all …]
|
| D | chrome_system_resources.h | 25 class ChromeSystemResources : public invalidation::SystemResources {
33 virtual invalidation::Time current_time();
39 virtual void ScheduleWithDelay(invalidation::TimeDelta delay,
40 invalidation::Closure* task);
42 virtual void ScheduleImmediately(invalidation::Closure* task);
44 virtual void ScheduleOnListenerThread(invalidation::Closure* task);
51 virtual void WriteState(const invalidation::string& state,
52 invalidation::StorageCallback* callback);
59 std::set<invalidation::Closure*> posted_tasks_;
68 Task* MakeTaskToPost(invalidation::Closure* task);
[all …]
|
| D | invalidation_util.h | 18 void RunAndDeleteClosure(invalidation::Closure* task);
21 invalidation::ObjectId* object_id);
23 bool ObjectIdToRealModelType(const invalidation::ObjectId& object_id,
29 std::string ObjectIdToString(const invalidation::ObjectId& object_id);
31 std::string ObjectIdPToString(const invalidation::ObjectIdP& object_id);
33 std::string StatusToString(const invalidation::Status& status);
36 const invalidation::Invalidation& invalidation);
39 const invalidation::RegistrationUpdate& update);
42 const invalidation::RegistrationUpdateResult& update_result);
|
| D | chrome_invalidation_client.h | 41 : public invalidation::InvalidationListener,
78 virtual void Invalidate(const invalidation::Invalidation& invalidation,
79 invalidation::Closure* callback) OVERRIDE;
80 virtual void InvalidateAll(invalidation::Closure* callback) OVERRIDE;
82 const invalidation::ObjectId& object_id,
83 invalidation::RegistrationState new_state,
84 const invalidation::UnknownHint& unknown_hint) OVERRIDE;
85 virtual void AllRegistrationsLost(invalidation::Closure* callback) OVERRIDE;
96 invalidation::NetworkEndpoint* const& network_endpoint);
104 scoped_ptr<invalidation::NetworkCallback> handle_outbound_packet_callback_;
[all …]
|
| D | cache_invalidation_packet_handler_unittest.cc | 22 class MockNetworkEndpoint : public invalidation::NetworkEndpoint {
25 void(invalidation::NetworkCallback*));
26 MOCK_METHOD1(HandleInboundMessage, void(const invalidation::string&));
27 MOCK_METHOD1(TakeOutboundMessage, void(invalidation::string*));
31 class MockInvalidationClient : public invalidation::InvalidationClient {
34 MOCK_METHOD1(Register, void(const invalidation::ObjectId&));
35 MOCK_METHOD1(Unregister, void(const invalidation::ObjectId&));
36 MOCK_METHOD0(network_endpoint, invalidation::NetworkEndpoint*());
|
| D | chrome_system_resources.cc | 34 invalidation::Time ChromeSystemResources::current_time() { in current_time()
55 invalidation::TimeDelta delay, in ScheduleWithDelay()
56 invalidation::Closure* task) { in ScheduleWithDelay()
68 invalidation::Closure* task) { in ScheduleImmediately()
81 invalidation::Closure* task) { in ScheduleOnListenerThread()
125 invalidation::StorageCallback* callback) { in RunAndDeleteStorageCallback()
131 const invalidation::string& state, in WriteState()
132 invalidation::StorageCallback* callback) { in WriteState()
141 invalidation::NewPermanentCallback( in WriteState()
147 invalidation::Closure* task) { in MakeTaskToPost()
[all …]
|
| D | chrome_invalidation_client_unittest.cc | 29 invalidation::InvalidationListener::UNKNOWN_OBJECT_VERSION;
46 invalidation::Closure* MakeClosure() { in MakeClosure()
47 return invalidation::NewPermanentCallback(this, &MockCallback::Run); in MakeClosure()
70 void (invalidation::NetworkCallback::*run_function)( in SimulateInformOutboundListener()
71 invalidation::NetworkEndpoint* const&) = in SimulateInformOutboundListener()
72 &invalidation::NetworkCallback::Run; in SimulateInformOutboundListener()
75 invalidation::NewPermanentCallback( in SimulateInformOutboundListener()
83 const invalidation::ObjectId object_id( in FireInvalidate()
84 invalidation::ObjectSource::CHROME_SYNC, type_name); in FireInvalidate()
86 const invalidation::Invalidation invalidation( in FireInvalidate() local
[all …]
|
| /external/chromium_org/chrome/browser/invalidation/ |
| D | invalidation_service_test_template.h | 90 : id1(ipc::invalidation::ObjectSource::CHROME_SYNC, "BOOKMARK"), in InvalidationServiceTest()
91 id2(ipc::invalidation::ObjectSource::CHROME_SYNC, "PREFERENCE"), in InvalidationServiceTest()
92 id3(ipc::invalidation::ObjectSource::CHROME_SYNC, "AUTOFILL"), in InvalidationServiceTest()
93 id4(ipc::invalidation::ObjectSource::CHROME_PUSH_MESSAGING, in InvalidationServiceTest()
97 invalidation::InvalidationService*
105 const invalidation::ObjectId id1;
106 const invalidation::ObjectId id2;
107 const invalidation::ObjectId id3;
108 const invalidation::ObjectId id4;
118 invalidation::InvalidationService* const invalidator = in TYPED_TEST_P()
[all …]
|
| /external/chromium_org/third_party/cacheinvalidation/ |
| D | cacheinvalidation.gyp | 12 # The C++ files generated from the cache invalidation protocol buffers.
42 # The main cache invalidation library. External clients should depend
63 'src/google/cacheinvalidation/impl/checking-invalidation-listener.cc',
64 'src/google/cacheinvalidation/impl/checking-invalidation-listener.h',
71 'src/google/cacheinvalidation/impl/invalidation-client-core.cc',
72 'src/google/cacheinvalidation/impl/invalidation-client-core.h',
73 'src/google/cacheinvalidation/impl/invalidation-client-factory.cc',
74 'src/google/cacheinvalidation/impl/invalidation-client-impl.cc',
75 'src/google/cacheinvalidation/impl/invalidation-client-impl.h',
76 'src/google/cacheinvalidation/impl/invalidation-client-util.h',
[all …]
|
| /external/chromium_org/chrome/browser/policy/cloud/ |
| D | cloud_policy_invalidator.h | 26 namespace invalidation {
59 void Initialize(invalidation::InvalidationService* invalidation_service);
87 void HandleInvalidation(const syncer::Invalidation& invalidation);
94 void Register(int64 timestamp, const invalidation::ObjectId& object_id);
139 invalidation::InvalidationService* invalidation_service_;
154 invalidation::ObjectId object_id_;
|