Home
last modified time | relevance | path

Searched refs:kvStorePtr_ (Results 1 - 25 of 36) sorted by relevance

12

/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/medialibrary_thumbnail_service_test/src/
H A Dmedialibrary_thumbnail_kvstore_test.cpp31 std::shared_ptr<MediaLibraryKvStore> kvStorePtr_ = nullptr; member
35 kvStorePtr_ = std::make_shared<MediaLibraryKvStore>(); in SetUpTestCase()
36 int errCode = kvStorePtr_->Init(KvStoreRoleType::OWNER, KvStoreValueType::MONTH_ASTC, TEST_PATH); in SetUpTestCase()
38 kvStorePtr_ = nullptr; in SetUpTestCase()
44 errCode = kvStorePtr_->Insert(FIRST_KEY, value); in SetUpTestCase()
49 errCode = kvStorePtr_->Insert(SECOND_KEY, value); in SetUpTestCase()
54 errCode = kvStorePtr_->Insert(THIRD_KEY, value); in SetUpTestCase()
61 if (kvStorePtr_ == nullptr) { in TearDownTestCase()
64 kvStorePtr_->Close(); in TearDownTestCase()
73 if (kvStorePtr_ in HWTEST_F()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/common/
H A Dkv_operator.cpp44 DistributedKv::Status status = dataManager_.GetSingleKvStore(options, appId, storeId, kvStorePtr_); in OpenKvStore()
56 if (kvStorePtr_ != nullptr) { in CloseKvStore()
57 dataManager_.CloseKvStore({ KVSTORE_APPID }, kvStorePtr_); in CloseKvStore()
58 kvStorePtr_ = nullptr; in CloseKvStore()
66 if (kvStorePtr_ == nullptr) { in GetValues()
73 DistributedKv::Status status = kvStorePtr_->Get(k, v); in GetValues()
88 if (kvStorePtr_ == nullptr) { in PutValues()
95 DistributedKv::Status status = kvStorePtr_->Put(k, v); in PutValues()
107 if (kvStorePtr_ == nullptr) { in SyncKvStore()
115 DistributedKv::Status status = kvStorePtr_ in SyncKvStore()
[all...]
H A Dkv_operator.h53 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_; member in OHOS::Sharing::final
/foundation/deviceprofile/device_info_manager/old/services/core/src/dbstorage/
H A Ddevice_profile_storage.cpp86 if (kvStorePtr_ == nullptr || observer == nullptr) { in SubscribeKvStore()
89 Status status = kvStorePtr_->SubscribeKvStore(SubscribeType::SUBSCRIBE_TYPE_REMOTE, observer); in SubscribeKvStore()
97 if (kvStorePtr_ == nullptr || observer == nullptr) { in UnSubscribeKvStore()
100 Status status = kvStorePtr_->UnSubscribeKvStore(SubscribeType::SUBSCRIBE_TYPE_REMOTE, observer); in UnSubscribeKvStore()
108 if (kvStorePtr_ == nullptr || sycnCb == nullptr) { in RegisterSyncCallback()
111 Status status = kvStorePtr_->RegisterSyncCallback(sycnCb); in RegisterSyncCallback()
119 if (kvStorePtr_ == nullptr) { in UnRegisterSyncCallback()
122 Status status = kvStorePtr_->UnRegisterSyncCallback(); in UnRegisterSyncCallback()
137 if (GetKvStore() == Status::SUCCESS && kvStorePtr_ != nullptr) { in TryGetKvStore()
143 if (kvStorePtr_ in TryGetKvStore()
[all...]
/foundation/deviceprofile/device_info_manager/services/core/src/persistenceadapter/kvadapter/
H A Dkv_adapter.cpp111 if (kvStorePtr_ == nullptr) { in Put()
118 if (kvStorePtr_->Get(kvKey, oldV) == DistributedKv::Status::SUCCESS && oldV.ToString() == value) { in Put()
126 status = kvStorePtr_->Put(kvKey, kvValue); in Put()
144 if (kvStorePtr_ == nullptr) { in PutBatch()
153 if (kvStorePtr_->Get(kvKey, oldV) == DistributedKv::Status::SUCCESS && oldV.ToString() == item.second) { in PutBatch()
169 status = kvStorePtr_->PutBatch(entries); in PutBatch()
183 if (kvStorePtr_ == nullptr) { in Delete()
188 status = kvStorePtr_->Delete(kvKey); in Delete()
206 if (kvStorePtr_ == nullptr) { in Get()
210 status = kvStorePtr_ in Get()
[all...]
/foundation/distributedhardware/device_manager/utils/src/kvadapter/
H A Dkv_adapter.cpp57 if (status == DistributedKv::Status::SUCCESS && kvStorePtr_) { in Init()
73 CHECK_NULL_RETURN(kvStorePtr_, ERR_DM_INIT_FAILED); in Init()
83 CHECK_NULL_VOID(kvStorePtr_); in UnInit()
85 kvStorePtr_.reset(); in UnInit()
106 CHECK_NULL_RETURN(kvStorePtr_, ERR_DM_POINT_NULL); in Put()
110 status = kvStorePtr_->Put(kvKey, kvValue); in Put()
127 CHECK_NULL_RETURN(kvStorePtr_, ERR_DM_POINT_NULL); in Get()
128 status = kvStorePtr_->Get(kvKey, kvValue); in Get()
159 DistributedKv::Status status = kvDataMgr_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_); in GetLocalKvStorePtr()
192 if (kvStorePtr_ in DeleteByAppId()
[all...]
/foundation/multimedia/media_library/frameworks/services/media_distributed/src/devices_info_interact/
H A Ddevices_info_interact.cpp38 if (kvStorePtr_ != nullptr) { in ~DevicesInfoInteract()
39 kvManager.CloseKvStore(appId, kvStorePtr_); in ~DevicesInfoInteract()
40 kvStorePtr_ = nullptr; in ~DevicesInfoInteract()
65 DistributedKv::Status status = kvManager.GetSingleKvStore(options, appId, storeId, kvStorePtr_); in Init()
80 if (kvStorePtr_ == nullptr) { in SyncMLDeviceInfos()
89 DistributedKv::Status status = kvStorePtr_->Sync(devices, DistributedKv::SyncMode::PULL, in SyncMLDeviceInfos()
96 if (kvStorePtr_ == nullptr) { in GetMLDeviceInfos()
105 DistributedKv::Status status = kvStorePtr_->Get(k, v); in GetMLDeviceInfos()
126 if (kvStorePtr_ == nullptr) { in PutMLDeviceInfos()
138 DistributedKv::Status status = kvStorePtr_ in PutMLDeviceInfos()
[all...]
/foundation/communication/dsoftbus/core/adapter/kv_store/src/
H A Dlnn_kv_adapter.cpp60 if (kvStorePtr_ && status == DistributedKv::Status::SUCCESS) { in Init()
102 if (kvStorePtr_ == nullptr) { in RegisterDataChangeListener()
107 kvStorePtr_->SubscribeKvStore(DistributedKv::SubscribeType::SUBSCRIBE_TYPE_CLOUD, dataChangeListener_); in RegisterDataChangeListener()
125 if (kvStorePtr_ == nullptr) { in UnRegisterDataChangeListener()
130 kvStorePtr_->UnSubscribeKvStore(DistributedKv::SubscribeType::SUBSCRIBE_TYPE_CLOUD, dataChangeListener_); in UnRegisterDataChangeListener()
158 if (kvStorePtr_ == nullptr) { in Put()
164 if (kvStorePtr_->Get(kvKey, oldV) == DistributedKv::Status::SUCCESS && oldV.ToString() == value) { in Put()
169 status = kvStorePtr_->Put(kvKey, kvValue); in Put()
188 if (kvStorePtr_ == nullptr) { in PutBatch()
197 if (kvStorePtr_ in PutBatch()
[all...]
/foundation/ability/ability_runtime/services/appmgr/src/
H A Dapp_config_data_manager.cpp37 if (kvStorePtr_ != nullptr) { in ~AppConfigDataManager()
38 dataManager_.CloseKvStore(APP_ID, kvStorePtr_); in ~AppConfigDataManager()
55 DistributedKv::Status status = dataManager_.GetSingleKvStore(options, APP_ID, STORE_ID, kvStorePtr_); in GetKvStore()
66 if (kvStorePtr_ != nullptr) { in CheckKvStore()
73 if (status == DistributedKv::Status::SUCCESS && kvStorePtr_ != nullptr) { in CheckKvStore()
79 return kvStorePtr_ != nullptr; in CheckKvStore()
103 status = kvStorePtr_->Put(key, value); in SetAppWaitingDebugInfo()
128 status = kvStorePtr_->Delete(key); in ClearAppWaitingDebugInfo()
153 status = kvStorePtr_->GetEntries(nullptr, allEntries); in GetAppWaitingDebugList()
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/
H A Ddistributed_data_storage.cpp129 if (GetKvStore() == Status::SUCCESS && kvStorePtr_ != nullptr) { in TryGetKvStore()
136 if (kvStorePtr_ == nullptr) { in TryGetKvStore()
153 Status status = dataManager_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_); in GetKvStore()
165 if (kvStorePtr_ == nullptr) { in SubscribeDistributedDataStorage()
172 Status status = kvStorePtr_->SubscribeKvStore(subscribeType, move(distributedDataChangeListener_)); in SubscribeDistributedDataStorage()
206 if (distributedDataChangeListener_ != nullptr && kvStorePtr_ != nullptr) { in UninitDistributedDataStorage()
208 status = kvStorePtr_->UnSubscribeKvStore(subscribeType, move(distributedDataChangeListener_)); in UninitDistributedDataStorage()
216 if (kvStorePtr_ != nullptr) { in UninitDistributedDataStorage()
222 kvStorePtr_ = nullptr; in UninitDistributedDataStorage()
265 if (kvStorePtr_ in InsertInnerLocked()
[all...]
H A Ddistributed_bm_storage.cpp150 Status status = kvStorePtr_->Put(publicKey, publicValue); in UpdatePublicRecords()
173 Status status = kvStorePtr_->Put(key, value); in InnerSaveStorageDistributeInfo()
175 status = kvStorePtr_->Put(key, value); in InnerSaveStorageDistributeInfo()
226 Status status = kvStorePtr_->Delete(key); in DeleteStorageDistributeInfo()
228 status = kvStorePtr_->Delete(key); in DeleteStorageDistributeInfo()
257 kvStorePtr_->Get(key, networkId, in GetStorageDistributeInfo()
292 Status status = kvStorePtr_->GetDeviceEntries(uuid, remoteEntries); in DealGetBundleName()
340 Status status = kvStorePtr_->GetDeviceEntries(uuid, newEntries); in DelReduData()
358 status = kvStorePtr_->DeleteBatch(reduKeyArr); in DelReduData()
376 if (kvStorePtr_ in CheckSyncData()
[all...]
H A Ddsched_sync_e2e.cpp259 Status status = kvStorePtr_->Sync(networkIdList, DistributedKv::SyncMode::PUSH_PULL, dataQuery, syncCallback); in PushAndPullData()
284 Status status = kvStorePtr_->Sync(networkIdList, DistributedKv::SyncMode::PUSH_PULL, dataQuery, syncCallback); in PushAndPullData()
324 if (kvStorePtr_ != nullptr) { in CheckKvStore()
330 if (status == Status::SUCCESS && kvStorePtr_ != nullptr) { in CheckKvStore()
338 return kvStorePtr_ != nullptr; in CheckKvStore()
359 Status status = dataManager_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_); in GetKvStore()
/foundation/multimedia/media_library/frameworks/innerkitsimpl/media_library_helper/src/
H A Dmedialibrary_kvstore.cpp56 if (kvStorePtr_ == nullptr) { in Insert()
57 MEDIA_ERR_LOG("kvStorePtr_ is nullptr"); in Insert()
65 Status status = kvStorePtr_->Put(k, v); in Insert()
74 if (kvStorePtr_ == nullptr) { in Delete()
75 MEDIA_ERR_LOG("kvStorePtr_ is nullptr"); in Delete()
82 Status status = kvStorePtr_->Delete(k); in Delete()
91 if (kvStorePtr_ == nullptr) { in Query()
92 MEDIA_ERR_LOG("kvStorePtr_ is nullptr"); in Query()
101 Status status = kvStorePtr_->Get(k, v); in Query()
183 if (kvStorePtr_ in BatchQuery()
[all...]
/foundation/ability/ability_runtime/services/abilitymgr/src/
H A Dapp_exit_reason_data_manager.cpp43 if (kvStorePtr_ != nullptr) { in ~AppExitReasonDataManager()
44 dataManager_.CloseKvStore(appId_, kvStorePtr_); in ~AppExitReasonDataManager()
59 DistributedKv::Status status = dataManager_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_); in GetKvStore()
71 if (kvStorePtr_ != nullptr) { in CheckKvStore()
77 if (status == DistributedKv::Status::SUCCESS && kvStorePtr_ != nullptr) { in CheckKvStore()
84 return kvStorePtr_ != nullptr; in CheckKvStore()
110 status = kvStorePtr_->Put(key, value); in SetAppExitReason()
152 DistributedKv::Status status = kvStorePtr_->GetEntries(nullptr, allEntries); in DeleteAppExitReason()
165 auto errCode = kvStorePtr_->Delete(item.key); in DeleteAppExitReason()
195 DistributedKv::Status status = kvStorePtr_ in GetAppExitReason()
[all...]
H A Dability_auto_startup_data_manager.cpp46 if (kvStorePtr_ != nullptr) { in ~AbilityAutoStartupDataManager()
47 dataManager_.CloseKvStore(APP_ID, kvStorePtr_); in ~AbilityAutoStartupDataManager()
62 DistributedKv::Status status = dataManager_.GetSingleKvStore(options, APP_ID, STORE_ID, kvStorePtr_); in GetKvStore()
74 if (kvStorePtr_ != nullptr) { in CheckKvStore()
80 if (status == DistributedKv::Status::SUCCESS && kvStorePtr_ != nullptr) { in CheckKvStore()
87 return kvStorePtr_ != nullptr; in CheckKvStore()
116 status = kvStorePtr_->Put(key, value); in InsertAutoStartupData()
151 status = kvStorePtr_->Delete(key); in UpdateAutoStartupData()
160 status = kvStorePtr_->Put(key, value); in UpdateAutoStartupData()
194 status = kvStorePtr_ in DeleteAutoStartupData()
[all...]
/foundation/bundlemanager/distributed_bundle_framework/services/dbms/src/
H A Ddistributed_data_storage.cpp118 Status status = kvStorePtr_->Put(key, value); in InnerSaveStorageDistributeInfo()
120 status = kvStorePtr_->Put(key, value); in InnerSaveStorageDistributeInfo()
154 Status status = kvStorePtr_->Delete(key); in DeleteStorageDistributeInfo()
156 status = kvStorePtr_->Delete(key); in DeleteStorageDistributeInfo()
192 Status status = kvStorePtr_->Get(key, value); in GetStorageDistributeInfo()
194 status = kvStorePtr_->Get(key, value); in GetStorageDistributeInfo()
200 kvStorePtr_->Delete(key); in GetStorageDistributeInfo()
236 Status status = kvStorePtr_->GetEntries(allEntryKeyPrefix, allEntries); in GetDistributedBundleName()
277 if (kvStorePtr_ != nullptr) { in CheckKvStore()
283 if (status == Status::SUCCESS && kvStorePtr_ ! in CheckKvStore()
[all...]
/foundation/deviceprofile/device_info_manager/old/services/core/test/unittest/
H A Dprofile_storage_test.cpp55 static std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_ = nullptr; member
775 onlineSyncTbl_->kvStorePtr_ = nullptr; in HWTEST_F()
789 onlineSyncTbl_->kvStorePtr_ = nullptr; in HWTEST_F()
805 onlineSyncTbl_->kvStorePtr_ = nullptr; in HWTEST_F()
820 onlineSyncTbl_->kvStorePtr_ = nullptr; in HWTEST_F()
836 onlineSyncTbl_->kvStorePtr_ = nullptr; in HWTEST_F()
851 onlineSyncTbl_->kvStorePtr_ = nullptr; in HWTEST_F()
867 onlineSyncTbl_->kvStorePtr_ = nullptr; in HWTEST_F()
882 onlineSyncTbl_->kvStorePtr_ = nullptr; in HWTEST_F()
896 onlineSyncTbl_->kvStorePtr_ in HWTEST_F()
[all...]
/foundation/ability/ability_runtime/test/unittest/ability_auto_startup_data_manager_test/
H A Dability_auto_startup_data_manager_test.cpp75 abilityAutoStartupDataManager.kvStorePtr_ = kvStorePtr; in HWTEST_F()
156 abilityAutoStartupDataManager.kvStorePtr_ = kvStorePtr; in HWTEST_F()
244 abilityAutoStartupDataManager.kvStorePtr_ = kvStorePtr; in HWTEST_F()
324 abilityAutoStartupDataManager.kvStorePtr_ = kvStorePtr; in HWTEST_F()
382 abilityAutoStartupDataManager.kvStorePtr_ = kvStorePtr; in HWTEST_F()
457 abilityAutoStartupDataManager.kvStorePtr_ = kvStorePtr; in HWTEST_F()
498 abilityAutoStartupDataManager.kvStorePtr_ = kvStorePtr; in HWTEST_F()
538 abilityAutoStartupDataManager.kvStorePtr_ = kvStorePtr; in HWTEST_F()
/foundation/ability/ability_runtime/services/appmgr/include/
H A Dapp_config_data_manager.h46 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_; member in OHOS::AbilityRuntime::AppConfigDataManager
/foundation/multimedia/media_library/frameworks/services/media_thumbnail/src/
H A Dthumbnail_service.cpp53 kvStorePtr_ = nullptr; in ThumbnailService()
127 kvStorePtr_ = kvStore; in Init()
143 kvStorePtr_ = nullptr; in ReleaseService()
374 .kvStore = kvStorePtr_, in GenerateThumbnailBackground()
464 .kvStore = kvStorePtr_, in LcdAging()
482 .kvStore = kvStorePtr_, in LcdDistributeAging()
497 .kvStore = kvStorePtr_, in InvalidateDistributeThumbnail()
537 .kvStore = kvStorePtr_, in GetAgingDataSize()
565 .kvStore = kvStorePtr_, in QueryNewThumbnailCount()
/foundation/multimedia/media_library/frameworks/services/media_distributed/include/devices_info_interact/
H A Ddevices_info_interact.h41 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_; member in OHOS::Media::final
/foundation/communication/dsoftbus/core/adapter/kv_store/include/
H A Dlnn_kv_adapter.h56 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_ = nullptr; member in OHOS::KVAdapter
/foundation/distributedhardware/device_manager/utils/include/kvadapter/
H A Dkv_adapter.h58 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_ = nullptr; member in OHOS::DistributedHardware::KVAdapter
/foundation/ability/dmsfwk/services/dtbschedmgr/include/mission/
H A Ddsched_sync_e2e.h63 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_; member in OHOS::DistributedSchedule::DmsKvSyncE2E
H A Ddistributed_data_storage.h113 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_; // protected by initLock_ member in OHOS::DistributedSchedule::DistributedDataStorage

Completed in 15 milliseconds

12