Home
last modified time | relevance | path

Searched refs:storeId_ (Results 1 – 25 of 62) sorted by relevance

123

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dsingle_store_impl.cpp43 storeId_ = dbStore_->GetStoreId(); in SingleStoreImpl()
55 BackupManager::GetInstance().Prepare(path, storeId_); in SingleStoreImpl()
72 return { storeId_ }; in GetStoreId()
611 StoreUtil::Anonymous(storeId_).c_str()); in CloudSync()
673 return service->DisableCapability({ appId_ }, { storeId_ }); in SetCapabilityEnabled()
701 StoreUtil::Anonymous(storeId_).c_str()); in SubscribeWithQuery()
723 StoreUtil::Anonymous(storeId_).c_str()); in UnsubscribeWithQuery()
761 StoreUtil::Anonymous(storeId_).c_str(), file.c_str()); in Backup()
771 service->Close({ appId_ }, { storeId_ }); in Restore()
843 StoreId storeId{ storeId_ }; in PutIn()
[all …]
H A Dobserver_bridge.cpp21 …: appId_(std::move(appId)), storeId_(std::move(store)), observer_(std::move(observer)), convert_(c… 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()
/ohos5.0/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/src/
H A Dsingle_store_impl.cpp26 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()
155 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in Commit()
171 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in Rollback()
197 ZLOGE("db:%{public}s already closed!", StoreUtil::Anonymous(storeId_).c_str()); in Get()
[all …]
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/resourcemanager/
H A Ddb_adapter.cpp50 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()
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()
363 if (storeId_.storeId == GLOBAL_CAPABILITY_ID) { in SyncDBForRecover()
369 if (storeId_.storeId == GLOBAL_VERSION_ID) { in SyncDBForRecover()
375 if (storeId_.storeId == GLOBAL_META_INFO) { in SyncDBForRecover()
[all …]
/ohos5.0/foundation/distributedhardware/device_manager/utils/src/kvadapter/
H A Dkv_adapter.cpp52 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()
/ohos5.0/foundation/communication/dsoftbus/core/adapter/kv_store/src/
H A Dlnn_kv_data_change_listener.cpp38 this->storeId_ = storeId; in KvDataChangeListener()
71 LnnCreateKvAdapter(&dbId, appId_.c_str(), appId_.length(), storeId_.c_str(), storeId_.length()); in ConvertCloudChangeDataToEntries()
H A Dlnn_kv_adapter.cpp42 this->storeId_.storeId = storeId; in KVAdapter()
54 LNN_LOGI(LNN_LEDGER, "Init kvAdapter, storeId: %{public}s", storeId_.storeId.c_str()); in Init()
316 status = kvDataMgr_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_); in GetKvStorePtr()
326 kvDataMgr_.CloseKvStore(appId_, storeId_); in DeleteKvStore()
327 kvDataMgr_.DeleteKvStore(appId_, storeId_, DATABASE_DIR); in DeleteKvStore()
/ohos5.0/foundation/deviceprofile/device_info_manager/services/core/src/deviceprofilemanager/listener/
H A Dkv_store_death_recipient.cpp36 storeId_ = storeId; in KvDeathRecipient()
60 auto reInitTask = [storeId = storeId_]() { in OnRemoteDied()
H A Dkv_data_change_listener.cpp45 storeId_ = storeId; in KvDataChangeListener()
55 HILOGI("storeId=%{public}s", storeId_.c_str()); in OnChange()
56 if (storeId_ == STATIC_STORE_ID) { in OnChange()
/ohos5.0/base/security/dlp_permission_service/services/dlp_permission/sa/storage/src/
H A Ddlp_kv_data_storage.cpp35 storeId_.storeId = storeId; in DlpKvDataStorage()
94 …OHOS::DistributedKv::Status status = dataManager_.GetSingleKvStore(options, appId_, storeId_, kvSt… in GetKvStore()
177 dataManager_.CloseKvStore(this->appId_, this->storeId_); in DeleteKvStore()
179 status = dataManager_.DeleteKvStore(this->appId_, this->storeId_, baseDir_); in DeleteKvStore()
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/
H A Ddsched_sync_e2e.cpp44 dataManager_.CloseKvStore(appId_, storeId_); in ~DmsKvSyncE2E()
193 Status status = dataManager_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_); in GetKvStore()
198 dataManager_.DeleteKvStore(appId_, storeId_, BMS_KV_BASE_DIR + appId_.appId); in GetKvStore()
H A Ddistributed_data_storage.cpp49 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()
/ohos5.0/base/account/os_account/services/accountmgr/src/
H A Daccount_data_storage.cpp32 storeId_.storeId = storeId; in AccountDataStorage()
70 …OHOS::DistributedKv::Status status = dataManager_.GetSingleKvStore(options, appId_, storeId_, kvSt… in GetKvStore()
217 dataManager_.CloseKvStore(this->appId_, this->storeId_); in DeleteKvStore()
218 status = dataManager_.DeleteKvStore(this->appId_, this->storeId_, baseDir_); in DeleteKvStore()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/
H A Druntime_store.cpp50 RuntimeStore::RuntimeStore(const std::string &storeId) : storeId_(storeId) in RuntimeStore()
53 ZLOGD("Construct runtimeStore: %{public}s.", Anonymous::Change(storeId_).c_str()); in RuntimeStore()
58 ZLOGD("Destruct runtimeStore: %{public}s.", Anonymous::Change(storeId_).c_str()); in ~RuntimeStore()
291 …ZLOGI("sync complete, %{public}s, status:%{public}d.", Anonymous::Change(storeId_).c_str(), dbStat… in Sync()
361 delegateManager_->GetKvStore(storeId_, option, in Init()
397 metaData.storeId = storeId_; in BuildMetaDataParam()
/ohos5.0/foundation/deviceprofile/device_info_manager/services/core/src/persistenceadapter/kvadapter/
H A Dkv_adapter.cpp47 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()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Dkv_store_nb_delegate_impl.cpp70 storeId_(storeId), in KvStoreNbDelegateImpl()
393 …StoreNbDelegate] 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()
859 LOGE("[KvStoreNbDelegate] [%s] Get the data failed:%d", storeId_.c_str(), errCode); in GetInner()
/ohos5.0/foundation/deviceprofile/device_info_manager/services/core/include/deviceprofilemanager/listener/
H A Dkv_store_death_recipient.h36 std::string storeId_; variable
H A Dkv_sync_completed_listener.h42 std::string storeId_; variable
H A Dkv_data_change_listener.h49 std::string storeId_;
/ohos5.0/foundation/communication/dsoftbus/core/adapter/kv_store/include/
H A Dlnn_kv_data_change_listener.h37 std::string storeId_; variable
/ohos5.0/foundation/deviceprofile/device_info_manager/services/core/test/unittest/
H A Dkv_store_death_recipient_test.cpp74 EXPECT_EQ(storeId, KvDeathRecipient_->storeId_);
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_general_store.cpp164 observer_.storeId_ = meta.storeId; in KVDBGeneralStore()
628 genOrigin.store = storeId_; in OnChange()
631 auto &info = changeInfo[storeId_][i]; in OnChange()
650 ConvertChangeData(inserts, changeData[storeId_][DistributedDB::OP_INSERT]); in OnChange()
651 ConvertChangeData(deletes, changeData[storeId_][DistributedDB::OP_DELETE]); in OnChange()
652 ConvertChangeData(updates, changeData[storeId_][DistributedDB::OP_UPDATE]); in OnChange()
655 genOrigin.store = storeId_; in OnChange()
/ohos5.0/foundation/deviceprofile/device_info_manager/old/services/core/src/dbstorage/
H A Ddevice_profile_storage.cpp47 storeId_.storeId = storeId; in DeviceProfileStorage()
153 Status status = dataManager_.GetSingleKvStore(options_, appId_, storeId_, kvStorePtr_); in GetKvStore()
164 Status status = dataManager_.DeleteKvStore(appId_, storeId_, options_.baseDir); in DeleteKvStore()
/ohos5.0/base/notification/common_event_service/services/include/
H A Dstatic_subscriber_data_manager.h48 const DistributedKv::StoreId storeId_ { "static_subscriber_infos" };
/ohos5.0/foundation/distributedhardware/device_manager/utils/include/kvadapter/
H A Dkv_adapter.h55 DistributedKv::StoreId storeId_; variable

123