Home
last modified time | relevance | path

Searched refs:storeId_ (Results 1 - 25 of 56) sorted by relevance

123

/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()
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 Dobserver_bridge.cpp21 : 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 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()
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 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()
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 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()
H A Dkv_sync_completed_listener.cpp39 storeId_ = storeId; in KvSyncCompletedListener()
/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()
/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.cpp43 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 Dkv_store_death_recipient.h36 std::string storeId_; member in OHOS::DistributedDeviceProfile::KvDeathRecipient
H A Dkv_sync_completed_listener.h42 std::string storeId_; member in OHOS::DistributedDeviceProfile::KvSyncCompletedListener
H A Dkv_data_change_listener.h49 std::string storeId_; member in OHOS::DistributedDeviceProfile::KvDataChangeListener
/foundation/communication/dsoftbus/core/adapter/kv_store/include/
H A Dlnn_kv_data_change_listener.h37 std::string storeId_; member in OHOS::KvDataChangeListener
H A Dlnn_kv_adapter.h54 DistributedKv::StoreId storeId_; member in OHOS::KVAdapter
/foundation/deviceprofile/device_info_manager/services/core/test/unittest/
H A Dkv_store_death_recipient_test.cpp74 EXPECT_EQ(storeId, KvDeathRecipient_->storeId_); in HWTEST_F()
/foundation/distributedhardware/device_manager/utils/include/kvadapter/
H A Dkv_adapter.h55 DistributedKv::StoreId storeId_; member in OHOS::DistributedHardware::KVAdapter
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/
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()
/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()
/foundation/ability/dmsfwk/services/dtbschedmgr/include/mission/
H A Ddsched_sync_e2e.h61 const DistributedKv::StoreId storeId_ {DISTRIBUTE_BM_STORE_ID};
H A Ddistributed_data_storage.h111 DistributedKv::StoreId storeId_; member in OHOS::DistributedSchedule::DistributedDataStorage
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Dkv_store_delegate_impl.h109 std::string storeId_; member in DistributedDB::final
H A Dkv_store_nb_delegate_impl.cpp70 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 Droute_head_handler_impl.h77 std::string storeId_; member in OHOS::DistributedData::RouteHeadHandlerImpl
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dobserver_bridge.h54 StoreId storeId_; member in OHOS::DistributedKv::ObserverBridge

Completed in 15 milliseconds

123