/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
H A D | single_store_impl.cpp | 43 storeId_ = dbStore_->GetStoreId(); in SingleStoreImpl() 55 BackupManager::GetInstance().Prepare(path, storeId_); in SingleStoreImpl() 72 return { storeId_ }; in GetStoreId() 92 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in Put() 119 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in PutBatch() 151 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in Delete() 176 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in DeleteBatch() 205 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in StartTransaction() 212 ZLOGE("status:0x%{public}x storeId:%{public}s", status, StoreUtil::Anonymous(storeId_).c_str()); in StartTransaction() 222 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_) in Commit() [all...] |
H A D | observer_bridge.cpp | 21 : appId_(std::move(appId)), storeId_(std::move(store)), observer_(std::move(observer)), convert_(cvt) in ObserverBridge() 34 service->Unsubscribe(appId_, storeId_, remote_); in ~ObserverBridge() 51 auto status = service->Subscribe(appId_, storeId_, remote_); in RegisterRemoteObserver() 76 status = service->Unsubscribe(appId_, storeId_, remote_); in UnregisterRemoteObserver()
|
/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/src/ |
H A D | single_store_impl.cpp | 26 storeId_ = dbStore_->GetStoreId(); in SingleStoreImpl() 32 return { storeId_ }; in GetStoreId() 39 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in Put() 63 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in PutBatch() 91 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in Delete() 113 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in DeleteBatch() 139 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in StartTransaction() 146 ZLOGE("status:0x%{public}x storeId:%{public}s", status, StoreUtil::Anonymous(storeId_).c_str()); in StartTransaction() 155 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in Commit() 162 ZLOGE("status:0x%{public}x storeId:%{public}s", status, StoreUtil::Anonymous(storeId_) in Commit() [all...] |
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/resourcemanager/ |
H A D | db_adapter.cpp | 50 this->storeId_.storeId = storeId; in DBAdapter() 82 return kvDataMgr_.GetSingleKvStore(options, appId_, storeId_, kvStoragePtr_); in GetKvStorePtr() 96 return kvDataMgr_.GetSingleKvStore(options, appId_, storeId_, kvStoragePtr_); in GetLocalKvStorePtr() 104 storeId_.storeId.c_str(), static_cast<int32_t>(dataType)); in Init() 118 kvDataMgr_.DeleteKvStore(appId_, storeId_, DATABASE_DIR + appId_.appId); in Init() 137 storeId_.storeId.c_str(), static_cast<int32_t>(this->dataType_)); in InitLocal() 175 DHLOGI("ReInit DB, storeId: %{public}s", storeId_.storeId.c_str()); in ReInit() 233 storeId_.storeId.c_str()); in SyncByNotFound() 246 GetAnonyString(key).c_str(), storeId_.storeId.c_str(), static_cast<int32_t>(this->dataType_)); in GetDataByKey() 260 if (this->dataType_ == DistributedKv::DataType::TYPE_STATICS && this->storeId_ in GetDataByKey() [all...] |
/foundation/deviceprofile/device_info_manager/services/core/src/deviceprofilemanager/listener/ |
H A D | kv_store_death_recipient.cpp | 36 storeId_ = storeId; in KvDeathRecipient() 60 auto reInitTask = [storeId = storeId_]() { in OnRemoteDied()
|
H A D | kv_data_change_listener.cpp | 45 storeId_ = storeId; in KvDataChangeListener() 55 HILOGI("storeId=%{public}s", storeId_.c_str()); in OnChange() 56 if (storeId_ == STATIC_STORE_ID) { in OnChange()
|
H A D | kv_sync_completed_listener.cpp | 39 storeId_ = storeId; in KvSyncCompletedListener()
|
/foundation/distributedhardware/device_manager/utils/src/kvadapter/ |
H A D | kv_adapter.cpp | 52 this->storeId_.storeId = STORE_ID; in Init() 142 LOGI("ReInit, storeId:%{public}s", storeId_.storeId.c_str()); in OnRemoteDied() 159 DistributedKv::Status status = kvDataMgr_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_); in GetLocalKvStorePtr() 178 kvDataMgr_.CloseKvStore(appId_, storeId_); in DeleteKvStore() 179 kvDataMgr_.DeleteKvStore(appId_, storeId_, DATABASE_DIR); in DeleteKvStore()
|
/foundation/communication/dsoftbus/core/adapter/kv_store/src/ |
H A D | lnn_kv_data_change_listener.cpp | 38 this->storeId_ = storeId; in KvDataChangeListener() 71 LnnCreateKvAdapter(&dbId, appId_.c_str(), appId_.length(), storeId_.c_str(), storeId_.length()); in ConvertCloudChangeDataToEntries()
|
H A D | lnn_kv_adapter.cpp | 43 this->storeId_.storeId = storeId; in KVAdapter() 55 LNN_LOGI(LNN_LEDGER, "Init kvAdapter, storeId: %{public}s", storeId_.storeId.c_str()); in Init() 325 status = kvDataMgr_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_); in GetKvStorePtr() 335 kvDataMgr_.CloseKvStore(appId_, storeId_); in DeleteKvStore() 336 kvDataMgr_.DeleteKvStore(appId_, storeId_, DATABASE_DIR); in DeleteKvStore()
|
/foundation/deviceprofile/device_info_manager/services/core/include/deviceprofilemanager/listener/ |
H A D | kv_store_death_recipient.h | 36 std::string storeId_; member in OHOS::DistributedDeviceProfile::KvDeathRecipient
|
H A D | kv_sync_completed_listener.h | 42 std::string storeId_; member in OHOS::DistributedDeviceProfile::KvSyncCompletedListener
|
H A D | kv_data_change_listener.h | 49 std::string storeId_; member in OHOS::DistributedDeviceProfile::KvDataChangeListener
|
/foundation/communication/dsoftbus/core/adapter/kv_store/include/ |
H A D | lnn_kv_data_change_listener.h | 37 std::string storeId_; member in OHOS::KvDataChangeListener
|
H A D | lnn_kv_adapter.h | 54 DistributedKv::StoreId storeId_; member in OHOS::KVAdapter
|
/foundation/deviceprofile/device_info_manager/services/core/test/unittest/ |
H A D | kv_store_death_recipient_test.cpp | 74 EXPECT_EQ(storeId, KvDeathRecipient_->storeId_); in HWTEST_F()
|
/foundation/distributedhardware/device_manager/utils/include/kvadapter/ |
H A D | kv_adapter.h | 55 DistributedKv::StoreId storeId_; member in OHOS::DistributedHardware::KVAdapter
|
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
H A D | distributed_data_storage.cpp | 49 storeId_.storeId = STORE_ID; in DistributedDataStorage() 153 Status status = dataManager_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_); in GetKvStore() 217 status = dataManager_.CloseKvStore(appId_, storeId_); in UninitDistributedDataStorage() 224 status = dataManager_.DeleteKvStore(appId_, storeId_, KVDB_PATH); in UninitDistributedDataStorage()
|
/foundation/deviceprofile/device_info_manager/services/core/src/persistenceadapter/kvadapter/ |
H A D | kv_adapter.cpp | 47 this->storeId_.storeId = storeId; in KVAdapter() 62 HILOGI("Init kvAdapter, storeId: %{public}s", storeId_.storeId.c_str()); in Init() 293 status = kvDataMgr_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_); in GetKvStorePtr() 532 kvDataMgr_.CloseKvStore(appId_, storeId_); in DeleteKvStore() 533 kvDataMgr_.DeleteKvStore(appId_, storeId_, DATABASE_DIR); in DeleteKvStore()
|
/foundation/ability/dmsfwk/services/dtbschedmgr/include/mission/ |
H A D | dsched_sync_e2e.h | 61 const DistributedKv::StoreId storeId_ {DISTRIBUTE_BM_STORE_ID};
|
H A D | distributed_data_storage.h | 111 DistributedKv::StoreId storeId_; member in OHOS::DistributedSchedule::DistributedDataStorage
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
H A D | kv_store_delegate_impl.h | 109 std::string storeId_; member in DistributedDB::final
|
H A D | kv_store_nb_delegate_impl.cpp | 70 storeId_(storeId), in KvStoreNbDelegateImpl() 393 LOGE("[KvStoreNbDelegate] The number of kv observers has been over limit, storeId[%.3s]", storeId_.c_str()); in RegisterDeviceObserver() 411 auto storeId = storeId_; in RegisterDeviceObserver() 442 storeId_.c_str()); in RegisterCloudObserver() 450 auto storeId = storeId_; in RegisterCloudObserver() 492 LOGE("[KvStoreNbDelegate] [%s] Observer has not been registered!", storeId_.c_str()); in UnRegisterDeviceObserver() 511 LOGW("[KvStoreNbDelegate] [%s] CloudObserver has not been registered!", storeId_.c_str()); in UnRegisterCloudObserver() 542 return storeId_; in GetStoreId() 929 LOGE("[KvStoreNbDelegate] [%s] Get the data failed:%d", storeId_.c_str(), errCode); in GetInner()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/session_manager/ |
H A D | route_head_handler_impl.h | 77 std::string storeId_;
member in OHOS::DistributedData::RouteHeadHandlerImpl
|
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/ |
H A D | observer_bridge.h | 54 StoreId storeId_; member in OHOS::DistributedKv::ObserverBridge
|