Searched refs:downloadAssets (Results 1 - 7 of 7) sorted by relevance
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
| H A D | object_asset_loader.cpp | 77 DistributedData::Assets downloadAssets; in TransferAssetsAsync() local
82 task.downloadAssets.insert(asset.uri); in TransferAssetsAsync()
83 downloadAssets.emplace_back(asset); in TransferAssetsAsync()
85 if (task.downloadAssets.empty()) { in TransferAssetsAsync()
91 executors_->Execute([this, userId, bundleName, deviceId, downloadAssets]() { in TransferAssetsAsync()
93 for (const auto& asset : downloadAssets) { in TransferAssetsAsync()
122 task.downloadAssets.erase(uri); in FinishTask()
123 if (task.downloadAssets.size() == 0 && task.callback != nullptr) { in FinishTask()
|
| H A D | object_asset_loader.h | 31 std::unordered_set<std::string> downloadAssets; member
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | object_asset_loader_test.cpp | 123 task.downloadAssets.insert(uri_); in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer_extend.cpp | 237 std::map<std::string, Assets> &downloadAssets) in DownloadAssetsOneByOne()
254 errCode = DownloadAssetsOneByOneInner(isSharedTable, info, downloadItem, downloadAssets); in DownloadAssetsOneByOne()
300 std::map<std::string, Assets> &downloadAssets = tmpAssetsToDownload; in BackFillAssetsAfterDownload() local
323 downloadAssets[col].push_back(asset); in BackFillAssetsAfterDownload()
326 return downloadAssets; in BackFillAssetsAfterDownload()
366 DownloadItem &downloadItem, std::map<std::string, Assets> &downloadAssets) in DownloadAssetsOneByOneInner()
372 for (auto &[col, assets] : downloadAssets) { in DownloadAssetsOneByOneInner()
400 downloadAssets = BackFillAssetsAfterDownload(downloadCode, deleteCode, tmpFlags, tmpAssetsToDownload, in DownloadAssetsOneByOneInner()
236 DownloadAssetsOneByOne(const InnerProcessInfo &info, DownloadItem &downloadItem, std::map<std::string, Assets> &downloadAssets) DownloadAssetsOneByOne() argument
365 DownloadAssetsOneByOneInner(bool isSharedTable, const InnerProcessInfo &info, DownloadItem &downloadItem, std::map<std::string, Assets> &downloadAssets) DownloadAssetsOneByOneInner() argument
|
| H A D | cloud_syncer.h | 362 std::map<std::string, Assets> &downloadAssets);
377 std::map<std::string, Assets> &downloadAssets);
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
| H A D | cloud_storage_utils.h | 92 static void MergeDownloadAsset(std::map<std::string, Assets> &downloadAssets,
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_storage_utils.cpp | 699 void CloudStorageUtils::MergeDownloadAsset(std::map<std::string, Assets> &downloadAssets, in MergeDownloadAsset() argument
703 auto downloadItem = downloadAssets.find(items.first); in MergeDownloadAsset()
704 if (downloadItem == downloadAssets.end()) { // LCOV_EXCL_BR_LINE in MergeDownloadAsset()
|
Completed in 13 milliseconds