| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/eventcenter/ |
| H A D | event_center.cpp | 19 thread_local EventCenter::AsyncQueue *EventCenter::asyncQueue_ = nullptr;
20 constexpr int32_t EventCenter::AsyncQueue::MAX_CAPABILITY;
21 EventCenter &EventCenter::GetInstance() in GetInstance()
23 static EventCenter eventCenter; in GetInstance()
27 bool EventCenter::Subscribe(int32_t evtId, const std::function<void(const Event &)> &observer) in Subscribe()
35 bool EventCenter::Unsubscribe(int32_t evtId) in Unsubscribe()
40 int32_t EventCenter::PostEvent(std::unique_ptr<Event> evt) const in PostEvent()
54 void EventCenter
[all...] |
| /foundation/distributeddatamgr/pasteboard/framework/framework/eventcenter/ |
| H A D | event_center.cpp | 18 thread_local EventCenter::AsyncQueue *EventCenter::asyncQueue_ = nullptr;
19 constexpr int32_t EventCenter::AsyncQueue::MAX_CAPABILITY;
20 EventCenter &EventCenter::GetInstance() in GetInstance()
22 static EventCenter eventCenter; in GetInstance()
26 bool EventCenter::Subscribe(int32_t evtId, const std::function<void(const Event &)> &observer) in Subscribe()
34 bool EventCenter::Unsubscribe(int32_t evtId) in Unsubscribe()
39 int32_t EventCenter::PostEvent(std::unique_ptr<Event> evt) const in PostEvent()
53 void EventCenter
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/ |
| H A D | event_center_test.cpp | 47 EventCenter::GetInstance().Subscribe(TEST_EVT_BEGIN, [this](const Event &evt) { in SetUp()
49 EventCenter::Defer defer; in SetUp()
50 EventCenter::GetInstance().PostEvent(std::make_unique<TestMiddle>()); in SetUp()
54 EventCenter::GetInstance().Subscribe(TEST_EVT_MIDDLE, [this](const Event &evt) { in SetUp()
56 EventCenter::Defer defer; in SetUp()
57 EventCenter::GetInstance().PostEvent(std::make_unique<TestEnd>()); in SetUp()
61 EventCenter::GetInstance().Subscribe(TEST_EVT_END, [this](const Event &evt) { in SetUp()
70 EventCenter::GetInstance().Unsubscribe(TEST_EVT_BEGIN); in TearDown()
71 EventCenter::GetInstance().Unsubscribe(TEST_EVT_MIDDLE); in TearDown()
72 EventCenter in TearDown()
[all...] |
| /foundation/distributeddatamgr/pasteboard/framework/test/src/ |
| H A D | event_center_test.cpp | 50 EventCenter::GetInstance().Subscribe(TEST_EVT_BEGIN, [this](const Event &evt) { in SetUp()
52 EventCenter::Defer defer; in SetUp()
53 EventCenter::GetInstance().PostEvent(std::make_unique<TestMiddle>()); in SetUp()
57 EventCenter::GetInstance().Subscribe(TEST_EVT_MIDDLE, [this](const Event &evt) { in SetUp()
59 EventCenter::Defer defer; in SetUp()
60 EventCenter::GetInstance().PostEvent(std::make_unique<TestEnd>()); in SetUp()
64 EventCenter::GetInstance().Subscribe(TEST_EVT_END, [this](const Event &evt) { in SetUp()
73 EventCenter::GetInstance().Unsubscribe(TEST_EVT_BEGIN); in TearDown()
74 EventCenter::GetInstance().Unsubscribe(TEST_EVT_MIDDLE); in TearDown()
75 EventCenter in TearDown()
[all...] |
| /foundation/distributeddatamgr/pasteboard/test/fuzztest/eventcenter_fuzzer/ |
| H A D | eventcenter_fuzzer.cpp | 51 EventCenter::GetInstance().Subscribe(evtId, [](const Event &evt) {
in FuzzEventCenterSubscribe()
53 EventCenter::GetInstance().Unsubscribe(evtId);
in FuzzEventCenterSubscribe()
63 EventCenter::GetInstance().PostEvent(nullptr);
in FuzzEventCenterPostEvent()
64 EventCenter::GetInstance().PostEvent(std::make_unique<Event>(evtId));
in FuzzEventCenterPostEvent()
74 EventCenter::Defer Defer([](const Event &evt) {
in FuzzEventCenterDefer()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/eventcenter/ |
| H A D | event_center.h | 26 class EventCenter { class
43 API_EXPORT static EventCenter &GetInstance();
|
| /foundation/distributeddatamgr/pasteboard/framework/framework/include/eventcenter/ |
| H A D | event_center.h | 26 class EventCenter { class
43 API_EXPORT static EventCenter &GetInstance();
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_service_impl.cpp | 122 EventCenter::GetInstance().Subscribe(CloudEvent::CLOUD_SYNC, process); in RdbServiceImpl()
123 EventCenter::GetInstance().Subscribe(CloudEvent::CLEAN_DATA, process); in RdbServiceImpl()
125 EventCenter::GetInstance().Subscribe(CloudEvent::MAKE_QUERY, [](const Event& event) { in RdbServiceImpl()
141 EventCenter::GetInstance().Subscribe(BindEvent::COMPENSATE_SYNC, compensateSyncProcess); in RdbServiceImpl()
142 EventCenter::GetInstance().Subscribe(BindEvent::RECOVER_SYNC, compensateSyncProcess); in RdbServiceImpl()
528 EventCenter::GetInstance().PostEvent(std::move(evt));
564 EventCenter::GetInstance().PostEvent(std::move(evt));
730 EventCenter::GetInstance().PostEvent(std::move(evt));
786 EventCenter::GetInstance().PostEvent(std::move(evt));
827 EventCenter
[all...] |
| H A D | rdb_general_store.cpp | 188 EventCenter::GetInstance().PostEvent(std::move(evt)); in Bind()
935 EventCenter::GetInstance().PostEvent(std::move(evt));
947 EventCenter::GetInstance().PostEvent(std::move(evt));
997 EventCenter::GetInstance().PostEvent(std::move(evt));
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/matrix/src/ |
| H A D | device_matrix.cpp | 356 EventCenter::Defer defer; in Broadcast()
365 EventCenter::GetInstance().PostEvent(std::make_unique<MatrixEvent>(MATRIX_BROADCAST, "", matrix)); in Broadcast()
380 EventCenter::GetInstance().PostEvent(std::make_unique<MatrixEvent>(MATRIX_BROADCAST, "", matrix)); in Broadcast()
396 EventCenter::Defer defer; in OnChanged()
425 EventCenter::GetInstance().PostEvent(std::make_unique<MatrixEvent>(MATRIX_BROADCAST, "", matrixData)); in OnChanged()
751 EventCenter::GetInstance().PostEvent(std::make_unique<MatrixEvent>(MATRIX_BROADCAST, "", matrixData)); in GenResetTask()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | sync_manager.cpp | 45 using Defer = EventCenter::Defer;
199 EventCenter::GetInstance().Subscribe(CloudEvent::LOCK_CLOUD_CONTAINER, GetLockChangeHandler()); in SyncManager()
200 EventCenter::GetInstance().Subscribe(CloudEvent::UNLOCK_CLOUD_CONTAINER, GetLockChangeHandler()); in SyncManager()
201 EventCenter::GetInstance().Subscribe(CloudEvent::LOCAL_CHANGE, GetClientChangeHandler()); in SyncManager()
324 EventCenter::GetInstance().PostEvent(std::move(evt)); in GetPostEventTask()
517 EventCenter::GetInstance().PostEvent(std::make_unique<CloudEvent>(CloudEvent::GET_SCHEMA, storeInfo));
|
| H A D | cloud_service_impl.cpp | 85 EventCenter::GetInstance().Subscribe(CloudEvent::GET_SCHEMA, [this](const Event &event) { in CloudServiceImpl()
88 EventCenter::GetInstance().Subscribe(CloudEvent::CLOUD_SHARE, [this](const Event &event) { in CloudServiceImpl()
233 EventCenter::GetInstance().PostEvent(std::make_unique<CloudEvent>(CloudEvent::CLEAN_DATA, storeInfo)); in DoClean()
1167 EventCenter::GetInstance().PostEvent(std::move(evt)); in AllocResourceAndShare()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
| H A D | object_asset_machine.cpp | 318 EventCenter::GetInstance().PostEvent(std::move(evt)); in CompensateSync()
346 EventCenter::GetInstance().PostEvent(std::move(evt)); in Recover()
|
| H A D | object_service_impl.cpp | 365 EventCenter::GetInstance().Subscribe(BindEvent::BIND_SNAPSHOT, process); in ObjectServiceImpl()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | kvstore_meta_manager.cpp | 115 EventCenter::GetInstance().Subscribe(DeviceMatrix::MATRIX_BROADCAST, [pipe](const Event &event) { in InitBroadcast()
364 EventCenter::GetInstance().PostEvent(std::move(evt)); in CloudSyncTask()
|
| H A D | kvstore_data_service.cpp | 263 EventCenter::Defer defer; in OnStart()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | cloud_data_test.cpp | 313 EventCenter::GetInstance().PostEvent(std::move(event)); in HWTEST_F()
678 EventCenter::GetInstance().Subscribe(CloudEvent::MAKE_QUERY, [](const Event &event) { in HWTEST_F()
898 EventCenter::GetInstance().PostEvent(std::move(event)); in HWTEST_F()
900 EventCenter::GetInstance().PostEvent(std::move(event1)); in HWTEST_F()
904 EventCenter::GetInstance().PostEvent(std::move(event2)); in HWTEST_F()
906 EventCenter::GetInstance().PostEvent(std::move(event3)); in HWTEST_F()
|
| H A D | device_matrix_test.cpp | 99 EventCenter::GetInstance().Unsubscribe(DeviceMatrix::MATRIX_BROADCAST); in TearDownTestCase()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_service_impl.cpp | 129 EventCenter::GetInstance().Subscribe(CloudEvent::CLOUD_SYNC, process); in Init()
130 EventCenter::GetInstance().Subscribe(CloudEvent::CLEAN_DATA, process); in Init()
675 EventCenter::GetInstance().PostEvent(move(event)); in BeforeCreate()
949 EventCenter::GetInstance().PostEvent(std::move(evt)); in DoCloudSync()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/ |
| H A D | auto_cache.cpp | 379 EventCenter::GetInstance().PostEvent(std::move(evt)); in PostDataChange()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/waterversion/ |
| H A D | water_version_manager.cpp | 67 EventCenter::GetInstance().Subscribe(CloudEvent::CLOUD_SYNC_FINISHED, [this](const Event &event) { in Init()
|
| /foundation/distributeddatamgr/pasteboard/services/core/src/ |
| H A D | pasteboard_service.cpp | 182 EventCenter::GetInstance().Subscribe(OHOS::MiscServices::Event::EVT_REMOTE_CHANGE, RemotePasteboardChange()); in OnStart()
202 EventCenter::GetInstance().Unsubscribe(PasteboardEvent::DISCONNECT); in OnStop()
204 EventCenter::GetInstance().Unsubscribe(OHOS::MiscServices::Event::EVT_REMOTE_CHANGE); in OnStop()
2320 EventCenter::GetInstance().Subscribe(PasteboardEvent::DISCONNECT, [this](const OHOS::MiscServices::Event &event) { in PasteboardEventSubscriber()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/ |
| H A D | data_share_service_impl.cpp | 551 EventCenter::GetInstance().Subscribe(RemoteChangeEvent::RDB_META_SAVE, [this](const Event &event) {
556 EventCenter::GetInstance().Subscribe(RemoteChangeEvent::DATA_CHANGE, [this](const Event &event) {
|