Home
last modified time | relevance | path

Searched refs:subscribeType (Results 1 - 17 of 17) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/
H A Dlocal_subscribe_store_test.cpp170 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; in HWTEST_F() local
174 Status status = kvStore->SubscribeKvStore(subscribeType, observer); in HWTEST_F()
178 status = kvStore->UnSubscribeKvStore(subscribeType, observer); in HWTEST_F()
193 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; in HWTEST_F() local
195 Status status = kvStore->SubscribeKvStore(subscribeType, observer); in HWTEST_F()
211 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; in HWTEST_F() local
212 Status status = kvStore->SubscribeKvStore(subscribeType, observer); in HWTEST_F()
221 status = kvStore->UnSubscribeKvStore(subscribeType, observer); in HWTEST_F()
237 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; in HWTEST_F() local
238 Status status = kvStore->SubscribeKvStore(subscribeType, observe in HWTEST_F()
268 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
303 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
346 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
381 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
415 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
462 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
524 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
561 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
598 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
618 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
657 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
699 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
722 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
743 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
773 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
807 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
853 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
905 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
951 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1007 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1052 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1087 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1130 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1173 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1214 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1275 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1337 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1398 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1460 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1508 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1548 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1586 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1635 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1682 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1726 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1759 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1815 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1867 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1923 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
[all...]
H A Dlocal_subscribe_device_store_test.cpp160 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; in HWTEST_F() local
162 Status status = kvStore_->SubscribeKvStore(subscribeType, observer); in HWTEST_F()
166 status = kvStore_->UnSubscribeKvStore(subscribeType, observer); in HWTEST_F()
181 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; in HWTEST_F() local
183 Status status = kvStore_->SubscribeKvStore(subscribeType, observer); in HWTEST_F()
198 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; in HWTEST_F() local
199 Status status = kvStore_->SubscribeKvStore(subscribeType, observer); in HWTEST_F()
208 status = kvStore_->UnSubscribeKvStore(subscribeType, observer); in HWTEST_F()
224 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; in HWTEST_F() local
225 Status status = kvStore_->SubscribeKvStore(subscribeType, observe in HWTEST_F()
255 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
290 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
333 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
368 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
403 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
450 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
512 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
549 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
586 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
606 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
645 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
687 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
710 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
731 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
761 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
795 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
841 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
893 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
939 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
995 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1039 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1074 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1117 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1160 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1201 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1262 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1324 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1385 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1447 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1495 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1535 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1573 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1622 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1669 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1713 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1746 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1802 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1854 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
1910 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; HWTEST_F() local
[all...]
H A Dsingle_kvstore_client_test.cpp952 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; in HWTEST_F() local
953 Status status = singleKvStore->SubscribeKvStore(subscribeType, observer); in HWTEST_F()
992 status = singleKvStore->UnSubscribeKvStore(subscribeType, observer); in HWTEST_F()
1009 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; in HWTEST_F() local
1010 Status status = singleKvStore->SubscribeKvStore(subscribeType, observer); in HWTEST_F()
1052 status = singleKvStore->UnSubscribeKvStore(subscribeType, observer); in HWTEST_F()
H A Ddevice_kvstore_test.cpp1065 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; in HWTEST_F() local
1066 Status status = kvStore_->SubscribeKvStore(subscribeType, observer); in HWTEST_F()
1105 status = kvStore_->UnSubscribeKvStore(subscribeType, observer); in HWTEST_F()
1122 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_ALL; in HWTEST_F() local
1123 Status status = kvStore_->SubscribeKvStore(subscribeType, observer); in HWTEST_F()
1165 status = kvStore_->UnSubscribeKvStore(subscribeType, observer); in HWTEST_F()
/foundation/distributeddatamgr/relational_store/frameworks/js/napi/rdb/src/
H A Dnapi_rdb_const_properties.cpp53 napi_value subscribeType = nullptr; in ExportSubscribeType() local
54 napi_create_object(env, &subscribeType); in ExportSubscribeType()
56 (void)SetNamedProperty(env, subscribeType, "SUBSCRIBE_TYPE_REMOTE", (int32_t)SubscribeMode::REMOTE); in ExportSubscribeType()
57 napi_object_freeze(env, subscribeType); in ExportSubscribeType()
58 return subscribeType; in ExportSubscribeType()
/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/
H A Djs_const_properties.cpp82 napi_value subscribeType = nullptr; in ExportSubscribeType() local
83 napi_create_object(env, &subscribeType); in ExportSubscribeType()
85 SetNamedProperty(env, subscribeType, "SUBSCRIBE_TYPE_LOCAL", (int32_t)SUBSCRIBE_LOCAL); in ExportSubscribeType()
86 SetNamedProperty(env, subscribeType, "SUBSCRIBE_TYPE_REMOTE", (int32_t)SUBSCRIBE_REMOTE); in ExportSubscribeType()
87 SetNamedProperty(env, subscribeType, "SUBSCRIBE_TYPE_ALL", (int32_t)SUBSCRIBE_LOCAL_REMOTE); in ExportSubscribeType()
88 napi_object_freeze(env, subscribeType); in ExportSubscribeType()
89 return subscribeType; in ExportSubscribeType()
H A Djs_single_kv_store.cpp116 auto subscribeType = ToSubscribeType(type); in ~JsSingleKVStore() local
117 kvStore_->UnSubscribeKvStore(subscribeType, observer); in ~JsSingleKVStore()
828 auto subscribeType = ToSubscribeType(type); in Subscribe() local
829 Status status = kvStore_->SubscribeKvStore(subscribeType, observer); in Subscribe()
841 auto subscribeType = ToSubscribeType(type); in UnSubscribe() local
842 Status status = kvStore_->UnSubscribeKvStore(subscribeType, observer); in UnSubscribe()
/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/
H A Djs_const_properties.cpp93 napi_value subscribeType = nullptr; in ExportSubscribeType() local
94 napi_create_object(env, &subscribeType); in ExportSubscribeType()
96 SetNamedProperty(env, subscribeType, "SUBSCRIBE_TYPE_LOCAL", (int32_t)SUBSCRIBE_LOCAL); in ExportSubscribeType()
97 SetNamedProperty(env, subscribeType, "SUBSCRIBE_TYPE_REMOTE", (int32_t)SUBSCRIBE_REMOTE); in ExportSubscribeType()
98 SetNamedProperty(env, subscribeType, "SUBSCRIBE_TYPE_ALL", (int32_t)SUBSCRIBE_LOCAL_REMOTE); in ExportSubscribeType()
99 napi_object_freeze(env, subscribeType); in ExportSubscribeType()
100 return subscribeType; in ExportSubscribeType()
H A Djs_kv_store.cpp76 auto subscribeType = ToSubscribeType(type); in ~JsKVStore() local
77 kvStore_->UnSubscribeKvStore(subscribeType, observer); in ~JsKVStore()
453 CHECK_ARGS_RETURN_VOID(ctxt, ValidSubscribeType(type), "invalid arg[1], i.e. invalid subscribeType"); in OnDataChange()
608 auto subscribeType = ToSubscribeType(type); in Subscribe() local
609 Status status = kvStore_->SubscribeKvStore(subscribeType, observer); in Subscribe()
621 auto subscribeType = ToSubscribeType(type); in UnSubscribe() local
622 Status status = kvStore_->UnSubscribeKvStore(subscribeType, observer); in UnSubscribe()
/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/
H A Dnapi_rdb_const_properties.cpp55 napi_value subscribeType = nullptr; in ExportSubscribeType() local
56 napi_create_object(env, &subscribeType); in ExportSubscribeType()
58 SET_NAPI_PROPERTY(subscribeType, "SUBSCRIBE_TYPE_REMOTE", int32_t(SubscribeMode::REMOTE)); in ExportSubscribeType()
59 SET_NAPI_PROPERTY(subscribeType, "SUBSCRIBE_TYPE_CLOUD", int32_t(SubscribeMode::CLOUD)); in ExportSubscribeType()
60 SET_NAPI_PROPERTY(subscribeType, "SUBSCRIBE_TYPE_CLOUD_DETAILS", int32_t(SubscribeMode::CLOUD_DETAIL)); in ExportSubscribeType()
61 SET_NAPI_PROPERTY(subscribeType, "SUBSCRIBE_TYPE_LOCAL_DETAILS", int32_t(SubscribeMode::LOCAL_DETAIL)); in ExportSubscribeType()
62 napi_object_freeze(env, subscribeType); in ExportSubscribeType()
63 return subscribeType; in ExportSubscribeType()
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/
H A Dkvstore_observer_nb_impl.h28 KvStoreObserverNbImpl(AppKvStoreObserver *appKvStoreObserver, const SubscribeType &subscribeType) in KvStoreObserverNbImpl() argument
31 subscribeType_ = subscribeType; in KvStoreObserverNbImpl()
/foundation/distributeddatamgr/relational_store/frameworks/cj/include/
H A Drelational_store_impl_rdbstore.h134 int32_t RegisterObserverArrStr(int32_t subscribeType, int64_t callbackId);
135 int32_t RegisterObserverChangeInfo(int32_t subscribeType, int64_t callbackId);
146 int32_t UnRegisterObserverArrStrChangeInfo(int32_t subscribeType, int64_t callbackId);
147 int32_t UnRegisterObserverArrStrChangeInfoAll(int32_t subscribeType);
H A Drelational_store_ffi.h224 FFI_EXPORT int32_t FfiOHOSRelationalStoreOnArrStr(int64_t id, int32_t subscribeType, int64_t callbackId);
226 FFI_EXPORT int32_t FfiOHOSRelationalStoreOnChangeInfo(int64_t id, int32_t subscribeType, int64_t callbackId);
234 FFI_EXPORT int32_t FfiOHOSRelationalStoreOffArrStrChangeInfo(int64_t id, int32_t subscribeType, int64_t callbackId);
236 FFI_EXPORT int32_t FfiOHOSRelationalStoreOffArrStrChangeInfoAll(int64_t id, int32_t subscribeType);
/foundation/distributeddatamgr/relational_store/frameworks/cj/src/
H A Drelational_store_ffi.cpp877 int32_t FfiOHOSRelationalStoreOnArrStr(int64_t id, int32_t subscribeType, int64_t callbackId) in FfiOHOSRelationalStoreOnArrStr() argument
883 return nativeRdbStore->RegisterObserverArrStr(subscribeType, callbackId); in FfiOHOSRelationalStoreOnArrStr()
886 int32_t FfiOHOSRelationalStoreOnChangeInfo(int64_t id, int32_t subscribeType, int64_t callbackId) in FfiOHOSRelationalStoreOnChangeInfo() argument
892 return nativeRdbStore->RegisterObserverChangeInfo(subscribeType, callbackId); in FfiOHOSRelationalStoreOnChangeInfo()
922 int32_t FfiOHOSRelationalStoreOffArrStrChangeInfo(int64_t id, int32_t subscribeType, int64_t callbackId) in FfiOHOSRelationalStoreOffArrStrChangeInfo() argument
928 return nativeRdbStore->UnRegisterObserverArrStrChangeInfo(subscribeType, callbackId); in FfiOHOSRelationalStoreOffArrStrChangeInfo()
931 int32_t FfiOHOSRelationalStoreOffArrStrChangeInfoAll(int64_t id, int32_t subscribeType) in FfiOHOSRelationalStoreOffArrStrChangeInfoAll() argument
937 return nativeRdbStore->UnRegisterObserverArrStrChangeInfoAll(subscribeType); in FfiOHOSRelationalStoreOffArrStrChangeInfoAll()
H A Drelational_store_impl_rdbstore.cpp370 int32_t RdbStoreImpl::RegisterObserverArrStr(int32_t subscribeType, int64_t callbackId) in RegisterObserverArrStr() argument
372 int32_t mode = subscribeType; in RegisterObserverArrStr()
390 int32_t RdbStoreImpl::RegisterObserverChangeInfo(int32_t subscribeType, int64_t callbackId) in RegisterObserverChangeInfo() argument
392 int32_t mode = subscribeType; in RegisterObserverChangeInfo()
491 int32_t RdbStoreImpl::UnRegisterObserverArrStrChangeInfo(int32_t subscribeType, int64_t callbackId) in UnRegisterObserverArrStrChangeInfo() argument
493 int32_t mode = subscribeType; in UnRegisterObserverArrStrChangeInfo()
520 int32_t RdbStoreImpl::UnRegisterObserverArrStrChangeInfoAll(int32_t subscribeType) in UnRegisterObserverArrStrChangeInfoAll() argument
522 int32_t mode = subscribeType; in UnRegisterObserverArrStrChangeInfoAll()
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/
H A Ddistributed_data_storage.cpp169 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_REMOTE; in SubscribeDistributedDataStorage() local
172 Status status = kvStorePtr_->SubscribeKvStore(subscribeType, move(distributedDataChangeListener_)); in SubscribeDistributedDataStorage()
207 SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_REMOTE; in UninitDistributedDataStorage() local
208 status = kvStorePtr_->UnSubscribeKvStore(subscribeType, move(distributedDataChangeListener_)); in UninitDistributedDataStorage()
/foundation/distributeddatamgr/kv_store/frameworks/cj/src/
H A Ddistributed_kv_store_impl.cpp645 auto subscribeType = ToSubscribeType(type); in OnDataChange() local
646 Status status = kvStore_->SubscribeKvStore(subscribeType, observer); in OnDataChange()
663 auto subscribeType = ToSubscribeType(type); in OffDataChange() local
664 Status status = kvStore_->UnSubscribeKvStore(subscribeType, *it); in OffDataChange()
682 auto subscribeType = ToSubscribeType(type); in OffAllDataChange() local
683 Status status = kvStore_->UnSubscribeKvStore(subscribeType, observer); in OffAllDataChange()

Completed in 21 milliseconds