| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_syncer_download_assets_test.cpp | 57 const string COL_ASSET = "asset";
145 Asset asset = ASSET_COPY; in GenerateDataRecords() local
146 asset.name = ASSET_COPY.name + std::to_string(i); in GenerateDataRecords()
147 assets.emplace_back(asset); in GenerateDataRecords()
148 asset.name = ASSET_COPY.name + std::to_string(i) + "_copy"; in GenerateDataRecords()
149 assets.emplace_back(asset); in GenerateDataRecords()
183 ASSERT_EQ(sqlite3_bind_null(stmt, 4), SQLITE_OK); // 4 is asset in InsertLocalData()
186 ASSERT_EQ(SQLiteUtils::BindBlobToStatement(stmt, 4, assetBlob, false), E_OK); // 4 is asset in InsertLocalData()
333 for (auto &asset : item.second) { in CheckDownloadForTest001()
334 EXPECT_EQ(AssetOperationUtils::EraseBitMask(asset in CheckDownloadForTest001()
370 Asset asset = ASSET_COPY; UpdateAssetsForLocal() local
[all...] |
| H A D | cloud_db_sync_utils_test.cpp | 93 Asset asset = g_cloudAsset1; in InsertCloudTableRecord() local
94 asset.name = asset.name + std::to_string(i); in InsertCloudTableRecord()
95 assetIsNull ? data.insert_or_assign("asset", Nil()) : data.insert_or_assign("asset", asset); in InsertCloudTableRecord()
124 Asset asset = g_cloudAsset2; in UpdateCloudTableRecord() local
125 asset.name = asset.name + std::to_string(i); in UpdateCloudTableRecord()
126 assetIsNull ? data.insert_or_assign("asset", Ni in UpdateCloudTableRecord()
[all...] |
| H A D | virtual_cloud_data_translate.h | 26 std::vector<uint8_t> AssetToBlob(const Asset &asset) override;
|
| H A D | virtual_cloud_db.cpp | 644 auto &asset = std::get<Asset>(recordData.second); in AddAssetIdForExtend() local
645 if (asset.flag == static_cast<uint32_t>(DistributedDB::AssetOpType::INSERT)) { in AddAssetIdForExtend()
646 asset.assetId = "10"; in AddAssetIdForExtend()
648 extend[recordData.first] = asset; in AddAssetIdForExtend()
660 for (auto &asset : assets) { in AddAssetsIdInner()
661 if (asset.flag == static_cast<uint32_t>(DistributedDB::AssetOpType::INSERT)) { in AddAssetsIdInner()
662 asset.assetId = "10"; in AddAssetsIdInner()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/ |
| H A D | mod.rs | 16 mod asset; modules
25 pub(crate) use asset::AssetLoader;
26 pub use asset::{CloudAsset, CloudAssets};
|
| H A D | connect.rs | 23 use crate::ipc_conn::asset::{CloudAsset, CloudAssets};
71 /// Normal. Everything works fine for the asset.
73 /// The asset is about to be inserted.
75 /// The asset is about to be updated.
77 /// The asset is about to be deleted.
79 /// The asset is abnormal and something is wrong with it.
81 /// The asset is being downloading.
205 FieldRaw::Asset(asset) => { in serialize()
207 parcel.write(asset) in serialize()
243 let asset in deserialize()
[all...] |
| H A D | asset.rs | 248 let asset = receive
251 results.push(Ok(asset))
300 let asset = receive
303 results.push(Ok(asset))
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.cpp | 106 void CloudSyncUtils::StatusToFlagForAsset(Asset &asset) in StatusToFlagForAsset() argument
108 asset.flag = static_cast<uint32_t>(StatusToFlag(static_cast<AssetStatus>(asset.status))); in StatusToFlagForAsset()
109 asset.status = static_cast<uint32_t>(AssetStatus::NORMAL); in StatusToFlagForAsset()
114 for (Asset &asset : assets) { in StatusToFlagForAssets()
115 StatusToFlagForAsset(asset); in StatusToFlagForAssets()
515 auto &asset = *it; in FillAssetIdToAssetsData() local
516 if (asset.flag != static_cast<uint32_t>(AssetOpType::INSERT)) { in FillAssetIdToAssetsData()
523 if (asset.name == extendAsset.name && !extendAsset.assetId.empty()) { in FillAssetIdToAssetsData()
524 asset in FillAssetIdToAssetsData()
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
| H A D | cloud_storage_utils.h | 59 static void ObtainAssetFromVBucket(const VBucket &vBucket, VBucket &asset);
64 static int FillAssetBeforeDownload(Asset &asset);
65 static int FillAssetAfterDownloadFail(Asset &asset, Asset &dbAsset, AssetOperationUtils::AssetOpType assetOpType);
71 static int FillAssetAfterDownload(Asset &asset, Asset &dbAsset, AssetOperationUtils::AssetOpType assetOpType);
74 static int FillAssetBeforeUpload(Asset &asset, Asset &dbAsset, AssetOperationUtils::AssetOpType assetOpType);
77 static int FillAssetForUpload(Asset &asset, Asset &dbAsset, AssetOperationUtils::AssetOpType assetOpType);
80 static int FillAssetForUploadFailed(Asset &asset, Asset &dbAsset, AssetOperationUtils::AssetOpType assetOpType);
|
| /foundation/multimedia/ringtone_library/interfaces/inner_api/native/ |
| H A D | ringtone_fetch_result.h | 64 void SetRingtoneAsset(std::unique_ptr<T>& asset, std::shared_ptr<NativeRdb::ResultSet> &resultSet);
66 void GetObjectFromResultSet(std::unique_ptr<T>& asset, std::shared_ptr<NativeRdb::ResultSet> &resultSet);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
| H A D | extension_util.h | 47 static DBAsset ConvertAsset(OhCloudExtCloudAsset *asset);
63 static void ConvertAssetLeft(OhCloudExtCloudAsset *asset, DBAsset &dbAsset);
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/cloudsync_fuzzer/ |
| H A D | cloudsync_fuzzer.cpp | 157 Asset asset; in GenAsset() local
158 asset.name = name; in GenAsset()
159 asset.hash = hash; in GenAsset()
160 return asset; in GenAsset()
223 Asset asset = g_cloudAsset; in InsertCloudTableRecord() local
224 asset.name = asset.name + std::to_string(i); in InsertCloudTableRecord()
225 assetIsNull ? data.insert_or_assign("assert", Nil()) : data.insert_or_assign("assert", asset); in InsertCloudTableRecord()
|
| /foundation/filemanagement/dfs_service/services/cloudsyncservice/src/ipc/ |
| H A D | cloud_sync_service.cpp | 635 LOGE("get asset downloader failed"); in DownloadFile()
639 Asset asset; in DownloadFile() local
640 asset.assetName = assetInfoObj.assetName; in DownloadFile()
642 asset.uri = GetHmdfsPath(assetInfoObj.uri, userId); in DownloadFile()
643 if (asset.uri.empty()) { in DownloadFile()
649 DownloadAssetInfo assetsToDownload{assetInfoObj.recordType, assetInfoObj.recordId, {}, asset, {}}; in DownloadFile()
667 LOGE("get asset downloader failed"); in DownloadFiles()
673 Asset asset; in DownloadFiles() local
674 asset.assetName = obj.assetName; in DownloadFiles()
675 asset in DownloadFiles()
[all...] |
| /foundation/arkui/ace_engine/frameworks/core/components/theme/ |
| H A D | theme_constants.cpp | 492 auto asset = assetManager->GetAsset(fileFullPath); in LoadCustomStyle() local
493 ThemeConstants::LoadFile(asset); in LoadCustomStyle()
531 void ThemeConstants::LoadFile(const RefPtr<Asset>& asset) in LoadFile() argument
533 if (!asset) { in LoadFile()
537 auto fileSize = asset->GetSize(); in LoadFile()
541 const auto& fileData = asset->GetData(); in LoadFile()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/common/ |
| H A D | value_proxy.h | 58 Asset(DistributedData::Asset asset);
59 Asset(CommonType::AssetValue asset);
60 Asset(NativeRdb::AssetValue asset);
61 Asset(DistributedDB::Asset asset);
68 static uint32_t ConvertToDataStatus(const DistributedDB::Asset &asset);
77 explicit TempAsset(DistributedDB::Asset asset);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
| H A D | object_service_stub.cpp | 64 ZLOGE("Unmarshal assetValue fail, asset name: %{public}s", assetValue.name.c_str()); in OnAssetChangedOnRemote()
79 ObjectStore::Asset asset; in ObjectStoreBindAssetOnRemote() local
81 if (!ITypesUtil::Unmarshal(data, bundleName, sessionId, asset, bindInfo)) { in ObjectStoreBindAssetOnRemote()
84 asset.name.c_str(), bindInfo.storeName.c_str()); in ObjectStoreBindAssetOnRemote()
88 int32_t status = BindAssetStore(bundleName, sessionId, asset, bindInfo); in ObjectStoreBindAssetOnRemote()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_asset_loader.cpp | 57 for (auto& asset : assets) { in PostEvent()
58 auto* downLoadAssets = Traits::get_if<DistributedData::Assets>(&asset.second); in PostEvent()
|
| /foundation/distributeddatamgr/data_object/interfaces/jskits/ |
| H A D | distributed_data_object.js | 198 let asset = object[key];
201 asset[subKey] = data[subKey];
207 let asset = {};
209 Object.defineProperty(asset, subKey, {
220 return asset;
|
| /foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
| H A D | rdb_sqlite_shared_result_set_test.cpp | 225 Asset asset;
in HWTEST_F() local
226 rstSet->GetAsset(5, asset);
in HWTEST_F()
227 EXPECT_EQ(asset.version, 1);
in HWTEST_F()
228 EXPECT_EQ(asset.name, "name1");
in HWTEST_F()
229 EXPECT_EQ(asset.uri, "uri1");
in HWTEST_F()
230 EXPECT_EQ(asset.status, Asset::STATUS_INSERT);
in HWTEST_F()
235 * @tc.desc: normal testcase of SqliteSharedResultSet for asset and assets
261 Asset asset;
in HWTEST_F() local
262 rstSet->GetAsset(5, asset);
in HWTEST_F()
263 EXPECT_EQ(asset in HWTEST_F()
[all...] |
| H A D | common.h | 32 AssetValue asset; member
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | object_asset_loader_test.cpp | 46 Asset asset{ in SetUp()
53 asset_ = asset; in SetUp()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | db_common.cpp | 818 DistributedDB::Asset asset = assets.at(i); in RemoveDuplicateAssetsData() local
819 auto it = indexMap.find(asset.name); in RemoveDuplicateAssetsData()
821 indexMap[asset.name] = i; in RemoveDuplicateAssetsData()
828 indexMap[asset.name] = i; in RemoveDuplicateAssetsData()
831 if (asset.assetId.empty()) { in RemoveDuplicateAssetsData()
833 indexMap[asset.name] = prevIndex; in RemoveDuplicateAssetsData()
838 if (ConvertToUInt(asset.modifyTime, modifyTime) && ConvertToUInt(prevAsset.modifyTime, prevModifyTime) && in RemoveDuplicateAssetsData()
839 !asset.modifyTime.empty() && !prevAsset.modifyTime.empty()) { in RemoveDuplicateAssetsData()
841 indexMap[asset.name] = modifyTime > prevModifyTime ? i : prevIndex; in RemoveDuplicateAssetsData()
845 indexMap[asset in RemoveDuplicateAssetsData()
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_relational_remove_device_data_test.cpp | 147 Asset asset = g_localAsset; in InsertUserTableRecord() local
148 asset.name = asset.name + std::to_string(i); in InsertUserTableRecord()
149 RuntimeContext::GetInstance()->AssetToBlob(asset, assetBlob); in InsertUserTableRecord()
165 Asset asset = g_localAsset; in InsertUserTableRecord() local
166 asset.name = g_localAsset.name + std::to_string(i); in InsertUserTableRecord()
167 assets.push_back(asset); in InsertUserTableRecord()
168 asset.name = g_localAsset.name + std::to_string(i + 1); in InsertUserTableRecord()
169 assets.push_back(asset); in InsertUserTableRecord()
203 Asset asset in InsertCloudTableRecord() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/cloud/ |
| H A D | icloud_data_translate.h | 30 virtual std::vector<uint8_t> AssetToBlob(const Asset &asset) = 0;
|
| /foundation/filemanagement/dfs_service/interfaces/inner_api/native/cloud_file_kit_inner/ |
| H A D | cloud_info.h | 38 Asset asset; member
|