Home
last modified time | relevance | path

Searched refs:CloudEvent (Results 1 - 23 of 23) sorted by relevance

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/
H A Dcloud_event.cpp19 CloudEvent::CloudEvent(int32_t evtId, StoreInfo storeInfo) in CloudEvent() function in OHOS::DistributedData::CloudEvent
24 const StoreInfo &CloudEvent::GetStoreInfo() const in GetStoreInfo()
29 int32_t CloudEvent::GetEventId() const in GetEventId()
H A Dcloud_sync_finished_event.cpp20 : CloudEvent(CLOUD_SYNC_FINISHED, storeMetaData.GetStoreInfo()), metaData_(storeMetaData) in CloudSyncFinishedEvent()
H A Dcloud_lock_event.cpp20 : CloudEvent(evtId, storeInfo), callback_(std::move(callback)) in CloudLockEvent()
H A Dcloud_share_event.cpp20 : CloudEvent(CLOUD_SHARE, std::move(storeInfo)), query_(std::move(query)), callback_(std::move(callback)) in CloudShareEvent()
H A Dsync_event.cpp54 : CloudEvent(CLOUD_SYNC, std::move(storeInfo)), info_(std::move(info)) in SyncEvent()
59 : CloudEvent(evtId, std::move(storeInfo)), info_(std::move(info)) in SyncEvent()
H A Dmake_query_event.cpp21 : CloudEvent(MAKE_QUERY, std::move(storeInfo)), predicates_(std::move(predicates)), columns_(columns), in MakeQueryEvent()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/
H A Dcloud_event.h25 class API_EXPORT CloudEvent : public Event { class
45 CloudEvent(int32_t evtId, StoreInfo storeInfo);
46 ~CloudEvent() = default;
H A Dcloud_sync_finished_event.h25 class API_EXPORT CloudSyncFinishedEvent : public CloudEvent {
H A Dcloud_lock_event.h24 class API_EXPORT CloudLockEvent : public CloudEvent {
H A Dmake_query_event.h27 class API_EXPORT MakeQueryEvent : public CloudEvent {
H A Dcloud_share_event.h23 class API_EXPORT CloudShareEvent : public CloudEvent {
H A Dsync_event.h22 class API_EXPORT SyncEvent : public CloudEvent {
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/commonevent/
H A Ddata_sync_event.h22 class API_EXPORT DataSyncEvent : public CloudEvent {
30 : CloudEvent(DATA_SYNC, std::move(storeInfo)), syncMode_(syncMode), status_(std::move(status)), in DataSyncEvent()
H A Ddata_change_event.h22 class API_EXPORT DataChangeEvent : public CloudEvent {
34 : CloudEvent(DATA_CHANGE, std::move(storeInfo)), info_(std::move(evtInfo)) in DataChangeEvent()
H A Dset_searchable_event.h22 class API_EXPORT SetSearchableEvent : public CloudEvent {
30 : CloudEvent(evtId, std::move(storeInfo)), info_(std::move(evtInfo)) in SetSearchableEvent()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/
H A Dsync_manager.cpp187 if (evt.GetEventId() == CloudEvent::LOCK_CLOUD_CONTAINER) { in GetLockChangeHandler()
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()
373 Defer defer(GetSyncHandler(std::move(retryer)), CloudEvent::CLOUD_SYNC);
517 EventCenter::GetInstance().PostEvent(std::make_unique<CloudEvent>(CloudEvent::GET_SCHEMA, storeInfo));
H A Dcloud_service_impl.h95 using CloudEvent = DistributedData::CloudEvent;
H A Dcloud_service_impl.cpp85 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()
970 auto &rdbEvent = static_cast<const CloudEvent &>(event); in GetSchema()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_service_impl.cpp101 auto &evt = static_cast<const CloudEvent &>(event); in RdbServiceImpl()
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()
287 return PostSearchEvent(CloudEvent::SET_SEARCH_TRIGGER, param, eventInfo); in SetDistributedTables()
826 auto event = std::make_unique<CloudEvent>(CloudEvent::GET_SCHEMA, std::move(storeInfo));
1141 return PostSearchEvent(CloudEvent::SET_SEARCHABLE, param, eventInfo);
1227 auto evt = std::make_unique<CloudLockEvent>(CloudEvent::LOCK_CLOUD_CONTAINER, std::move(storeInfo), callback);
1249 auto evt = std::make_unique<CloudLockEvent>(CloudEvent
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_service_impl.cpp98 const auto &evt = static_cast<const CloudEvent &>(event); in Init()
129 EventCenter::GetInstance().Subscribe(CloudEvent::CLOUD_SYNC, process); in Init()
130 EventCenter::GetInstance().Subscribe(CloudEvent::CLEAN_DATA, process); in Init()
674 auto event = std::make_unique<CloudEvent>(CloudEvent::GET_SCHEMA, storeInfo); in BeforeCreate()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/
H A Dcloud_test.cpp541 CloudEvent event(evtId, info); in HWTEST_F()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/waterversion/
H A Dwater_version_manager.cpp67 EventCenter::GetInstance().Subscribe(CloudEvent::CLOUD_SYNC_FINISHED, [this](const Event &event) { in Init()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dcloud_data_test.cpp312 auto event = std::make_unique<CloudEvent>(CloudEvent::GET_SCHEMA, storeInfo); in HWTEST_F()
678 EventCenter::GetInstance().Subscribe(CloudEvent::MAKE_QUERY, [](const Event &event) { in HWTEST_F()

Completed in 19 milliseconds