Home
last modified time | relevance | path

Searched refs:objectKey (Results 1 - 4 of 4) sorted by relevance

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/
H A Dobject_data_listener.cpp52 auto objectKey = dstBundleName + sessionId; in OnStart() local
53 ZLOGI("OnStart, objectKey:%{public}s", objectKey.c_str()); in OnStart()
54 ObjectStoreManager::GetInstance()->NotifyAssetsStart(objectKey, srcNetworkId); in OnStart()
68 auto objectKey = assetObj->dstBundleName_+assetObj->sessionId_; in OnFinished() local
69 ZLOGI("OnFinished, status:%{public}d objectKey:%{public}s, asset size:%{public}zu", result, objectKey.c_str(), in OnFinished()
71 ObjectStoreManager::GetInstance()->NotifyAssetsReady(objectKey, assetObj->dstBundleName_, srcNetworkId); in OnFinished()
H A Dobject_manager.cpp264 auto objectKey = bundleName + sessionId; in Retrieve() local
265 restoreStatus_.ComputeIfPresent(objectKey, [&allReady](const auto &key, auto &value) { in Retrieve()
462 void ObjectStoreManager::ComputeStatus(const std::string& objectKey, const SaveInfo& saveInfo, in ComputeStatus() argument
465 restoreStatus_.Compute(objectKey, [this, &data, saveInfo] (const auto &key, auto &value) { in ComputeStatus()
490 for (auto const& [objectKey, results] : data) { in NotifyDataChanged()
492 objectKey, [](const std::string& key) -> auto { in NotifyDataChanged()
495 ComputeStatus(objectKey, saveInfo, data); in NotifyDataChanged()
499 int32_t ObjectStoreManager::WaitAssets(const std::string& objectKey, const SaveInfo& saveInfo, in WaitAssets() argument
502 auto taskId = executors_->Schedule(std::chrono::seconds(WAIT_TIME), [this, objectKey, data, saveInfo]() { in WaitAssets()
503 ZLOGE("wait assets finisehd timeout, try pull assets, objectKey in WaitAssets()
534 NotifyAssetsReady(const std::string& objectKey, const std::string& bundleName, const std::string& srcNetworkId) NotifyAssetsReady() argument
568 NotifyAssetsStart(const std::string& objectKey, const std::string& srcNetworkId) NotifyAssetsStart() argument
655 DoNotifyAssetsReady(uint32_t tokenId, const CallbackInfo& value, const std::string& objectKey, bool allReady) DoNotifyAssetsReady() argument
676 DoNotifyWaitAssetTimeout(const std::string &objectKey) DoNotifyWaitAssetTimeout() argument
[all...]
H A Dobject_manager.h99 void NotifyAssetsReady(const std::string& objectKey, const std::string& bundleName,
101 void NotifyAssetsStart(const std::string& objectKey, const std::string& srcNetworkId = "");
168 void DoNotifyAssetsReady(uint32_t tokenId, const CallbackInfo& value, const std::string& objectKey, bool allReady);
169 void DoNotifyWaitAssetTimeout(const std::string &objectKey);
175 void ComputeStatus(const std::string& objectKey, const SaveInfo& saveInfo,
180 int32_t WaitAssets(const std::string& objectKey, const SaveInfo& saveInfo,
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dobject_manager_test.cpp222 std::string objectKey = bundleName1_ + sessionId_; in HWTEST_F() local
229 data1 = {{ "objectKey", data1_ }}; in HWTEST_F()
230 data = {{ objectKey, data1 }}; in HWTEST_F()
233 ASSERT_EQ(manager->restoreStatus_.Find(objectKey).first, false); in HWTEST_F()
235 ASSERT_EQ(manager->restoreStatus_.Find(objectKey).second, RestoreStatus::DATA_READY); in HWTEST_F()
248 std::string objectKey = bundleName_ + sessionId_; in HWTEST_F() local
250 ASSERT_EQ(manager->restoreStatus_.Find(objectKey).first, false); in HWTEST_F()
251 manager->NotifyAssetsReady(objectKey, srcNetworkId); in HWTEST_F()
252 ASSERT_EQ(manager->restoreStatus_.Find(objectKey).second, RestoreStatus::ASSETS_READY); in HWTEST_F()
254 manager->restoreStatus_.Insert(objectKey, RestoreStatu in HWTEST_F()
267 std::string objectKey="com.example.myapplicaiton123456"; HWTEST_F() local
369 std::string objectKey="com.example.myapplicaiton123456"; HWTEST_F() local
[all...]

Completed in 4 milliseconds