| /foundation/distributeddatamgr/pasteboard/test/fuzztest/eventcenter_fuzzer/ |
| H A D | eventcenter_fuzzer.cpp | 38 int32_t evtId = TypeCast<int32_t>(rawData);
in FuzzPbEventGetNetworkId() local
39 PasteboardEvent pbEvt(evtId, "pasteboard_fuzz_test");
in FuzzPbEventGetNetworkId()
50 int32_t evtId = TypeCast<int32_t>(rawData);
in FuzzEventCenterSubscribe() local
51 EventCenter::GetInstance().Subscribe(evtId, [](const Event &evt) {
in FuzzEventCenterSubscribe()
53 EventCenter::GetInstance().Unsubscribe(evtId);
in FuzzEventCenterSubscribe()
62 int32_t evtId = TypeCast<int32_t>(rawData);
in FuzzEventCenterPostEvent() local
64 EventCenter::GetInstance().PostEvent(std::make_unique<Event>(evtId));
in FuzzEventCenterPostEvent()
73 int32_t evtId = TypeCast<int32_t>(rawData);
in FuzzEventCenterDefer() local
75 }, evtId);
in FuzzEventCenterDefer()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/eventcenter/ |
| H A D | event_center.cpp | 27 bool EventCenter::Subscribe(int32_t evtId, const std::function<void(const Event &)> &observer) in Subscribe() argument
29 return observers_.Compute(evtId, [&observer](const auto &id, auto &list) -> bool { in Subscribe()
35 bool EventCenter::Unsubscribe(int32_t evtId) in Unsubscribe() argument
37 return observers_.Erase(evtId); in Unsubscribe()
66 EventCenter::Defer::Defer(std::function<void(const Event &)> handler, int32_t evtId) in Defer() argument
77 asyncQueue_->AddHandler(evtId, std::move(handler)); in Defer()
140 void EventCenter::AsyncQueue::AddHandler(int32_t evtId, std::function<void(const Event &)> handler) in AddHandler() argument
142 if (evtId == Event::EVT_INVALID || handler == nullptr) { in AddHandler()
147 if (handlers_.find(evtId) != handlers_.end()) { in AddHandler()
151 handlers_[evtId] in AddHandler()
[all...] |
| H A D | event.cpp | 19 Event::Event(int32_t evtId) : evtId_(evtId) in Event() argument
|
| /foundation/distributeddatamgr/pasteboard/framework/framework/eventcenter/ |
| H A D | event_center.cpp | 26 bool EventCenter::Subscribe(int32_t evtId, const std::function<void(const Event &)> &observer) in Subscribe() argument
28 return observers_.Compute(evtId, [&observer](const auto &id, auto &list) -> bool { in Subscribe()
34 bool EventCenter::Unsubscribe(int32_t evtId) in Unsubscribe() argument
36 return observers_.Erase(evtId); in Unsubscribe()
65 EventCenter::Defer::Defer(std::function<void(const Event &)> handler, int32_t evtId) in Defer() argument
76 asyncQueue_->AddHandler(evtId, std::move(handler)); in Defer()
139 void EventCenter::AsyncQueue::AddHandler(int32_t evtId, std::function<void(const Event &)> handler) in AddHandler() argument
141 if (evtId == Event::EVT_INVALID || handler == nullptr) { in AddHandler()
146 if (handlers_.find(evtId) != handlers_.end()) { in AddHandler()
150 handlers_[evtId] in AddHandler()
[all...] |
| H A D | pasteboard_event.cpp | 19 PasteboardEvent::PasteboardEvent(int32_t evtId, std::string networkId) : Event(evtId), networkId_(std::move(networkId)) in PasteboardEvent() argument
|
| H A D | event.cpp | 18 Event::Event(int32_t evtId) : evtId_(evtId) {} in Event() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/ |
| H A D | cloud_event.cpp | 19 CloudEvent::CloudEvent(int32_t evtId, StoreInfo storeInfo) in CloudEvent() argument
20 : Event(evtId), eventId_(evtId), storeInfo_(std::move(storeInfo)) in CloudEvent()
|
| H A D | cloud_lock_event.cpp | 19 CloudLockEvent::CloudLockEvent(int32_t evtId, StoreInfo storeInfo, Callback callback) in CloudLockEvent() argument
20 : CloudEvent(evtId, storeInfo), callback_(std::move(callback)) in CloudLockEvent()
|
| H A D | cloud_sync_finished_event.cpp | 19 CloudSyncFinishedEvent::CloudSyncFinishedEvent(int32_t evtId, const StoreMetaData &storeMetaData) in CloudSyncFinishedEvent() argument
|
| H A D | sync_event.cpp | 58 SyncEvent::SyncEvent(int32_t evtId, StoreInfo storeInfo, EventInfo info) in SyncEvent() argument
59 : CloudEvent(evtId, std::move(storeInfo)), info_(std::move(info)) in SyncEvent()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/eventcenter/ |
| H A D | event_center.h | 36 API_EXPORT Defer(std::function<void(const Event &)> handler = nullptr, int32_t evtId = Event::EVT_INVALID);
44 API_EXPORT bool Subscribe(int32_t evtId, const std::function<void(const Event &)> &observer);
45 API_EXPORT bool Unsubscribe(int32_t evtId);
56 void AddHandler(int32_t evtId, std::function<void(const Event &)> handler);
|
| H A D | event.h | 35 API_EXPORT Event(int32_t evtId);
|
| /foundation/distributeddatamgr/pasteboard/framework/framework/include/eventcenter/ |
| H A D | event_center.h | 36 API_EXPORT Defer(std::function<void(const Event &)> handler = nullptr, int32_t evtId = Event::EVT_INVALID);
44 API_EXPORT bool Subscribe(int32_t evtId, const std::function<void(const Event &)> &observer);
45 API_EXPORT bool Unsubscribe(int32_t evtId);
57 void AddHandler(int32_t evtId, std::function<void(const Event &)> handler);
|
| H A D | pasteboard_event.h | 30 PasteboardEvent(int32_t evtId, std::string networkId);
|
| H A D | event.h | 32 API_EXPORT Event(int32_t evtId);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/changeevent/ |
| H A D | remote_change_event.cpp | 19 RemoteChangeEvent::RemoteChangeEvent(int32_t evtId, DataInfo&& info) in RemoteChangeEvent() argument
20 : Event(evtId), info_(std::move(info)) in RemoteChangeEvent()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/snapshot/ |
| H A D | bind_event.cpp | 19 BindEvent::BindEvent(int32_t evtId, BindEventInfo&& bindInfo) : Event(evtId), bindInfo_(std::move(bindInfo)) in BindEvent() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/commonevent/ |
| H A D | set_searchable_event.h | 29 SetSearchableEvent(StoreInfo storeInfo, EventInfo evtInfo, int32_t evtId = SET_SEARCHABLE) in SetSearchableEvent()
30 : CloudEvent(evtId, std::move(storeInfo)), info_(std::move(evtInfo)) in SetSearchableEvent()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/matrix/src/ |
| H A D | matrix_event.cpp | 17 MatrixEvent::MatrixEvent(int32_t evtId, const std::string &device, const MatrixData &data) in MatrixEvent() argument
18 : Event(evtId), data_(data), deviceId_(device) in MatrixEvent()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | cloud_sync_finished_event.h | 27 CloudSyncFinishedEvent(int32_t evtId, const StoreMetaData &storeMetaData);
|
| H A D | cloud_lock_event.h | 27 CloudLockEvent(int32_t evtId, StoreInfo storeInfo, Callback callback);
|
| H A D | cloud_event.h | 45 CloudEvent(int32_t evtId, StoreInfo storeInfo);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/snapshot/ |
| H A D | bind_event.h | 45 BindEvent(int32_t evtId, BindEventInfo&& bindInfo);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/changeevent/ |
| H A D | remote_change_event.h | 40 RemoteChangeEvent(int32_t evtId, DataInfo&& info);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/matrix/include/ |
| H A D | matrix_event.h | 36 MatrixEvent(int32_t evtId, const std::string &device, const MatrixData &data);
|