/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
H A D | raw_data_parser_test.cpp | 126 ValueObject::Assets assets(1);
in HWTEST_F() 127 assets[0].id = "100";
in HWTEST_F() 128 assets[0].name = "IMG_1690.png";
in HWTEST_F() 129 assets[0].uri = "file://data/args/header/IMG_1690.png";
in HWTEST_F() 130 assets[0].createTime = "2024-07-05 20:37.982158265 +8:00";
in HWTEST_F() 131 assets[0].modifyTime = "2024-07-05 20:37.982158265 +8:00";
in HWTEST_F() 132 assets[0].size = "4194304";
in HWTEST_F() 133 assets[0].hash = "2024-07-05 20:37.982158265 +8:00_4194304";
in HWTEST_F() 134 assets[0].path = "photos/header/IMG_1690.png";
in HWTEST_F() 135 auto rawData = RawDataParser::PackageRawData(assets);
in HWTEST_F() [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
H A D | rdb_asset_loader_test.cpp | 54 const DistributedData::Value &prefix, VBucket &assets) override
60 const DistributedData::Value &prefix, VBucket &assets) override
89 std::map<std::string, DistributedDB::Assets> assets;
in HWTEST_F() local 90 assets["asset1"].push_back(g_rdbAsset);
in HWTEST_F() 91 auto result = rdbAssetLoader.Download(tableName, groupId, prefix, assets);
in HWTEST_F() 107 std::vector<DistributedDB::Asset> assets;
in HWTEST_F() local 108 assets.push_back(g_rdbAsset);
in HWTEST_F() 109 auto result = rdbAssetLoader.RemoveLocalAssets(assets);
in HWTEST_F() 129 std::map<std::string, DistributedDB::Assets> assets;
in HWTEST_F() local 130 assets["asset in HWTEST_F() [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
H A D | virtual_asset_loader.cpp | 20 std::map<std::string, Assets> &assets) in Download() 30 downloadCallBack_(assets); in Download() 32 for (auto &item: assets) { in Download() 41 DBStatus VirtualAssetLoader::RemoveLocalAssets(const std::vector<Asset> &assets) in RemoveLocalAssets() argument 44 return removeAssetsCallBack_(assets); in RemoveLocalAssets() 50 std::map<std::string, Assets> &assets) in RemoveLocalAssets() 59 removeLocalAssetsCallBack_(assets); in RemoveLocalAssets() 62 for (auto &item: assets) { in RemoveLocalAssets() 19 Download(const std::string &tableName, const std::string &gid, const Type &prefix, std::map<std::string, Assets> &assets) Download() argument 49 RemoveLocalAssets(const std::string &tableName, const std::string &gid, const Type &prefix, std::map<std::string, Assets> &assets) RemoveLocalAssets() argument
|
H A D | virtual_cloud_data_translate.cpp | 36 uint32_t CalculateLens(const Assets &assets) in CalculateLens() argument 39 for (const auto &asset : assets) { in CalculateLens() 82 std::vector<uint8_t> VirtualCloudDataTranslate::AssetsToBlob(const Assets &assets) in AssetsToBlob() argument 87 srcLen += CalculateLens(assets); in AssetsToBlob() 90 parcel.WriteUInt32(assets.size()); in AssetsToBlob() 91 for (const auto &asset : assets) { in AssetsToBlob() 109 Assets assets; in BlobToAssets() local 110 assets.resize(count); in BlobToAssets() 112 ReadAsset(parcel, assets[i]); in BlobToAssets() 114 return assets; in BlobToAssets() [all...] |
H A D | virtual_asset_loader.h | 22 using DownloadCallBack = std::function<void (std::map<std::string, Assets> &assets)>; 23 using RemoveAssetsCallBack = std::function<DBStatus (const std::vector<Asset> &assets)>; 24 using RemoveLocalAssetsCallBack = std::function<void (std::map<std::string, Assets> &assets)>; 31 std::map<std::string, Assets> &assets) override; 33 DBStatus RemoveLocalAssets(const std::vector<Asset> &assets) override; 36 std::map<std::string, Assets> &assets) override;
|
H A D | distributeddb_cloud_syncer_lock_test.cpp | 52 const string COL_ASSETS = "assets"; 125 void UpdateCloudAssets(Asset &asset, Assets &assets, const std::string &version); 211 Assets assets; in GenerateDataRecords() local 214 assets.emplace_back(asset); in GenerateDataRecords() 218 assets.emplace_back(asset); in GenerateDataRecords() 221 data.insert_or_assign(COL_ASSETS, assets); in GenerateDataRecords() 255 ASSERT_EQ(SQLiteUtils::BindBlobToStatement(stmt, 4, assetsBlob, false), E_OK); // 4 is assets in InsertLocalData() 387 std::string sql = "SELECT asset, assets FROM " + ASSETS_TABLE_NAME + ";"; in CheckAssetStatusNormal() 399 Assets assets = g_virtualCloudDataTranslate->BlobToAssets(std::get<Bytes>(assetsBlob)); in CheckAssetStatusNormal() local 400 for (const auto &as : assets) { in CheckAssetStatusNormal() 408 UpdateCloudAssets(Asset &asset, Assets &assets, const std::string &version) UpdateCloudAssets() argument 742 Assets assets = { b1, b3 }; HWTEST_F() local 806 Assets assets = { b1, b2 }; HWTEST_F() local 988 Assets assets; HWTEST_F() local [all...] |
H A D | distributeddb_cloud_db_proxy_test.cpp | 569 Assets assets; in HWTEST_F() local 574 assets.push_back(asset1); in HWTEST_F() 580 assets.push_back(asset2); in HWTEST_F() 586 assets.push_back(asset3); in HWTEST_F() 592 assets.push_back(asset4); in HWTEST_F() 598 assets.push_back(asset5); in HWTEST_F() 604 assets.push_back(asset6); in HWTEST_F() 610 assets.push_back(asset7); in HWTEST_F() 612 DBCommon::RemoveDuplicateAssetsData(assets); in HWTEST_F() 620 EXPECT_EQ(assets in HWTEST_F() 855 std::vector<Asset> assets; HWTEST_F() local 897 Assets assets = {{}}; HWTEST_F() local [all...] |
H A D | distributeddb_cloud_syncer_download_assets_test.cpp | 58 const string COL_ASSETS = "assets"; 144 Assets assets; in GenerateDataRecords() local 147 assets.emplace_back(asset); in GenerateDataRecords() 149 assets.emplace_back(asset); in GenerateDataRecords() 154 data.insert_or_assign(COL_ASSETS, assets); in GenerateDataRecords() 190 ASSERT_EQ(SQLiteUtils::BindBlobToStatement(stmt, 5, assetsBlob, false), E_OK); // 5 is assets in InsertLocalData() 197 void UpdateLocalData(sqlite3 *&db, const std::string &tableName, const Assets &assets) in UpdateLocalData() argument 201 const string sql = "update " + tableName + " set assets=?;"; in UpdateLocalData() 204 assetBlob = g_virtualCloudDataTranslate->AssetsToBlob(assets); in UpdateLocalData() 210 void UpdateLocalData(sqlite3 *&db, const std::string &tableName, const Assets &assets, int32_ argument 330 CheckDownloadForTest001(int index, map<std::string, Assets> &assets) CheckDownloadForTest001() argument 354 Assets assets; CheckDownloadFailedForTest002() local 369 Assets assets; UpdateAssetsForLocal() local 504 Assets assets = g_virtualCloudDataTranslate->BlobToAssets(std::get<Bytes>(cloudValue)); CheckLocaLAssets() local 1245 Assets assets; HWTEST_F() local 1560 Assets assets; HWTEST_F() local 2411 Assets assets; HWTEST_F() local 2460 Assets assets = g_virtualCloudDataTranslate->BlobToAssets(std::get<Bytes>(cloudValue)); HWTEST_F() local [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
H A D | rdb_asset_loader.cpp | 33 std::map<std::string, Assets> &assets) in Download() 35 DistributedData::VBucket downLoadAssets = ValueProxy::Convert(assets); in Download() 42 assets = ValueProxy::Convert(std::move(downLoadAssets)); in Download() 47 DBStatus RdbAssetLoader::RemoveLocalAssets(const std::vector<Asset> &assets) in RemoveLocalAssets() argument 49 DistributedData::VBucket deleteAssets = ValueProxy::Convert(std::map<std::string, Assets>{{ "", assets }}); in RemoveLocalAssets() 54 void RdbAssetLoader::PostEvent(std::set<std::string>& skipAssets, std::map<std::string, DistributedData::Value>& assets, in PostEvent() argument 57 for (auto& asset : assets) { in PostEvent() 66 void RdbAssetLoader::PostEvent(DistributedData::AssetEvent eventId, DistributedData::Assets& assets, in PostEvent() argument 69 for (auto& downLoadAsset : assets) { in PostEvent() 32 Download(const std::string &tableName, const std::string &gid, const Type &prefix, std::map<std::string, Assets> &assets) Download() argument
|
H A D | rdb_asset_loader.h | 38 std::map<std::string, std::vector<Asset>> &assets) override; 40 DBStatus RemoveLocalAssets(const std::vector<Asset> &assets) override; 45 void PostEvent(std::set<std::string>& skipAssets, std::map<std::string, DistributedData::Value>& assets, 47 void PostEvent(DistributedData::AssetEvent eventId, DistributedData::Assets& assets,
|
H A D | rdb_cloud_data_translate.cpp | 45 std::vector<uint8_t> RdbCloudDataTranslate::AssetsToBlob(const Assets &assets) in AssetsToBlob() argument 48 auto num = DistributedData::HostToNet((uint16_t)assets.size()); in AssetsToBlob() 53 for (auto &asset : assets) { in AssetsToBlob() 71 DataAssets assets; in BlobToAssets() local 72 if (ParserRawData(blob.data(), blob.size(), assets) == 0) { in BlobToAssets() 75 return ValueProxy::Convert(assets); in BlobToAssets() 111 size_t RdbCloudDataTranslate::ParserRawData(const uint8_t *data, size_t length, DataAssets &assets) in ParserRawData() argument 141 assets.push_back(std::move(asset)); in ParserRawData()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/ |
H A D | asset_loader_test.cpp | 36 VBucket assets; in HWTEST_F() local 37 auto ret = loader.Download(tableName, gid, prefix, assets); in HWTEST_F() 43 * @tc.desc: remove local assets. 52 VBucket assets; in HWTEST_F() local 53 auto ret = loader.RemoveLocalAssets(tableName, gid, prefix, assets); in HWTEST_F()
|
/foundation/distributeddatamgr/relational_store/frameworks/cj/src/ |
H A D | relational_store_impl_resultsetproxy.cpp | 265 std::vector<NativeRdb::ValueObject::Asset> assets; in GetAssets() local 266 *rtnCode = resultSetValue->GetAssets(columnIndex, assets); in GetAssets() 267 if (*rtnCode != RelationalStoreJsKit::OK || assets.size() == 0) { in GetAssets() 270 Asset* result = static_cast<Asset*>(malloc(assets.size() * sizeof(Asset))); in GetAssets() 274 for (size_t i = 0; i < assets.size(); i++) { in GetAssets() 276 .name= MallocCString(assets[i].name), in GetAssets() 277 .uri= MallocCString(assets[i].uri), in GetAssets() 278 .path= MallocCString(assets[i].path), in GetAssets() 279 .createTime= MallocCString(assets[i].createTime), in GetAssets() 280 .modifyTime= MallocCString(assets[ in GetAssets() [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/cloud/ |
H A D | iAssetLoader.h | 32 std::map<std::string, Assets> &assets) in Download() 37 virtual DBStatus RemoveLocalAssets(const std::vector<Asset> &assets) in RemoveLocalAssets() argument 43 std::map<std::string, Assets> &assets) in RemoveLocalAssets() 31 Download(const std::string &tableName, const std::string &gid, const Type &prefix, std::map<std::string, Assets> &assets) Download() argument 42 RemoveLocalAssets(const std::string &tableName, const std::string &gid, const Type &prefix, std::map<std::string, Assets> &assets) RemoveLocalAssets() argument
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/common/ |
H A D | value_proxy.cpp | 355 ValueProxy::Assets::Assets(DistributedData::Assets assets) in Assets() argument 358 assets_.reserve(assets.size()); in Assets() 359 for (auto &asset : assets) { in Assets() 364 ValueProxy::Assets::Assets(NativeRdb::ValueObject::Assets assets) in Assets() argument 367 assets_.reserve(assets.size()); in Assets() 368 for (auto &asset : assets) { in Assets() 373 ValueProxy::Assets::Assets(CommonType::Assets assets) in Assets() argument 376 assets_.reserve(assets.size()); in Assets() 377 for (auto &asset : assets) { in Assets() 382 ValueProxy::Assets::Assets(DistributedDB::Assets assets) in Assets() argument 411 NativeRdb::ValueObject::Assets assets; operator NativeRdb::ValueObject::Assets() local 421 CommonType::Assets assets; operator CommonType::Assets() local 431 DistributedData::Assets assets; operator DistributedData::Assets() local 441 DistributedDB::Assets assets; operator DistributedDB::Assets() local [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | distributeddb_relational_cloud_syncable_storage_test.cpp | 115 Assets assets; in CreateAndInitUserTable() local 117 assets.push_back(asset); in CreateAndInitUserTable() 119 assets.push_back(asset); in CreateAndInitUserTable() 122 ASSERT_EQ(RuntimeContext::GetInstance()->AssetsToBlob(assets, assetsBlob), E_OK); in CreateAndInitUserTable() 209 void CheckGetAsset(VBucket &assets, uint32_t status) in CheckGetAsset() argument 211 EXPECT_EQ(assets.size(), 2u); in CheckGetAsset() 212 ASSERT_TRUE(assets["assert"].index() == TYPE_INDEX<Asset>); in CheckGetAsset() 213 ASSERT_TRUE(assets["asserts"].index() == TYPE_INDEX<Assets>); in CheckGetAsset() 214 Asset data1 = std::get<Asset>(assets["assert"]); in CheckGetAsset() 216 Assets data2 = std::get<Assets>(assets["assert in CheckGetAsset() 237 Assets assets; ConstructMultiDownloadData() local 318 Assets assets; fillCloudAssetTest() local 1012 Assets assets = std::get<Assets>(entry2->second); HWTEST_F() local 1114 Assets assets; HWTEST_F() local 1169 Assets assets; HWTEST_F() local 1224 Assets assets; HWTEST_F() local 1501 VBucket assets; HWTEST_F() local 1561 VBucket assets; HWTEST_F() local [all...] |
/foundation/graphic/graphic_3d/lume/LumeBinaryCompile/test/RofsBuild/ |
H A D | compile_rofs.sh | 25 cp -r $OPENHARMONY_DIR/foundation/graphic/graphic_3d/lume/Lume_3D/assets/3d/* 3d_source 27 cp -r $OPENHARMONY_DIR/foundation/graphic/graphic_3d/lume/LumeRender/assets/render/* render_source 29 cp -r $OPENHARMONY_DIR/foundation/graphic/graphic_3d/lume/LumeEngine/assets/render/* render_source 42 ./LumeShaderCompiler --optimize --source $PROJECT_ROOT/foundation/graphic/graphic_3d/lume/LumeRender/assets/render/shaders --include $PROJECT_ROOT/foundation/graphic/graphic_3d/lume/LumeRender/api/ 44 ./LumeShaderCompiler --optimize --source $PROJECT_ROOT/foundation/graphic/graphic_3d/lume/Lume_3D/assets/3d/shaders --include $PROJECT_ROOT/foundation/graphic/graphic_3d/lume/Lume_3D/api/ --include $PROJECT_ROOT/foundation/graphic/graphic_3d/lume/LumeRender/api/
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
H A D | distributeddb_cloud_assets_operation_sync_test.cpp | 44 "assets ASSETS," \ 190 {"photo", TYPE_INDEX<Bytes>}, {"asset", TYPE_INDEX<Asset>}, {"assets", TYPE_INDEX<Assets>}, in GetSchema() 219 std::vector<Asset> assets = GetAssets(name, templateAsset, assetCount); in InsertUserTableRecord() local 221 " (id, name, height, photo, asset, assets, age) VALUES ('" + std::to_string(i) + in InsertUserTableRecord() 225 RuntimeContext::GetInstance()->AssetsToBlob(assets, assetsBlob); in InsertUserTableRecord() 236 std::vector<Asset> assets; in GetAssets() local 246 assets.push_back(asset); in GetAssets() 248 return assets; in GetAssets() 261 Assets assets; in UpdateCloudTableRecord() local 267 assets in UpdateCloudTableRecord() 301 auto assets = RelationalTestUtils::GetAssets(colValue, translate); CheckAssetsCount() local 342 auto assets = RelationalTestUtils::GetAssets(colValue, translate, true); CheckAssetData() local 443 Assets assets; HWTEST_F() local 622 Assets assets; InsertLocalAssetData() local 867 auto assets = RelationalTestUtils::GetAllAssets(db_, dbSchema.tables[0], virtualTranslator_); HWTEST_F() local 1030 auto assets = RelationalTestUtils::GetAllAssets(db_, dbSchema.tables[0], virtualTranslator_); HWTEST_F() local [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
H A D | cloud_storage_utils.cpp | 128 Assets assets; in BindBlob() local 129 errCode = GetValueFromVBucket(field.colName, vBucket, assets); in BindBlob() 133 RuntimeContext::GetInstance()->AssetsToBlob(assets, val); in BindBlob() 175 Assets assets; in BindAsset() local 176 errCode = GetValueFromOneField(type, assets); in BindAsset() 178 LOGE("can not get assets from vBucket when bind, %d", errCode); in BindAsset() 181 if (!assets.empty()) { in BindAsset() 182 for (auto &asset: assets) { in BindAsset() 185 errCode = RuntimeContext::GetInstance()->AssetsToBlob(assets, val); in BindAsset() 188 LOGE("field type is not asset or assets, in BindAsset() 431 Assets assets; GetAssetFromAssets() local 494 FillAssetsAfterDownload(Assets &assets, Assets &dbAssets, const std::map<std::string, AssetOperationUtils::AssetOpType> &assetOpTypeMap) FillAssetsAfterDownload() argument 530 FillAssetsForUpload(Assets &assets, Assets &dbAssets, const std::map<std::string, AssetOperationUtils::AssetOpType> &assetOpTypeMap) FillAssetsForUpload() argument 556 FillAssetsBeforeUpload(Assets &assets, Assets &dbAssets, const std::map<std::string, AssetOperationUtils::AssetOpType> &assetOpTypeMap) FillAssetsBeforeUpload() argument 571 Assets assets; PrepareToFillAssetFromVBucket() local 668 IsAssetsContainDuplicateAsset(Assets &assets) IsAssetsContainDuplicateAsset() argument 718 GenAssetsIndexMap(Assets &assets) GenAssetsIndexMap() argument 784 CheckAssetStatus(const Assets &assets) CheckAssetStatus() argument 907 Assets assets; GetToBeRemoveAssets() local 928 FillAssetsForUploadFailed(Assets &assets, Assets &dbAssets, const std::map<std::string, AssetOperationUtils::AssetOpType> &assetOpTypeMap) FillAssetsForUploadFailed() argument 960 FillAssetsAfterDownloadFail(Assets &assets, Assets &dbAssets, const std::map<std::string, AssetOperationUtils::AssetOpType> &assetOpTypeMap) FillAssetsAfterDownloadFail() argument 966 MergeAssetWithFillFunc(Assets &assets, Assets &dbAssets, const std::map<std::string, AssetOperationUtils::AssetOpType> &assetOpTypeMap, std::function<int(Asset &, Asset &, AssetOperationUtils::AssetOpType)> fillAsset) MergeAssetWithFillFunc() argument 1342 const Assets *assets = std::get_if<TYPE_INDEX<Assets>>(&item.second); IsAbnormalData() local [all...] |
/foundation/distributeddatamgr/relational_store/interfaces/ndk/src/ |
H A D | relational_asset.cpp | 220 auto assets = new Data_Asset *[count]; in OH_Data_Asset_CreateMultiple() local 222 assets[i] = new Data_Asset(); in OH_Data_Asset_CreateMultiple() 224 return assets; in OH_Data_Asset_CreateMultiple() 227 int OH_Data_Asset_DestroyMultiple(Data_Asset **assets, uint32_t count) in OH_Data_Asset_DestroyMultiple() argument 230 delete assets[i]; in OH_Data_Asset_DestroyMultiple() 232 delete[] assets; in OH_Data_Asset_DestroyMultiple() 233 assets = nullptr; in OH_Data_Asset_DestroyMultiple()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/ |
H A D | asset_loader.cpp | 19 const std::string &tableName, const std::string &gid, const Value &prefix, VBucket &assets) in Download() 25 const std::string &tableName, const std::string &gid, const Value &prefix, VBucket &assets) in RemoveLocalAssets() 18 Download( const std::string &tableName, const std::string &gid, const Value &prefix, VBucket &assets) Download() argument 24 RemoveLocalAssets( const std::string &tableName, const std::string &gid, const Value &prefix, VBucket &assets) RemoveLocalAssets() argument
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
H A D | asset_loader_impl.cpp | 35 const std::string &tableName, const std::string &gid, const DBValue &prefix, DBVBucket &assets) in Download() 50 for (auto &[key, value] : assets) { in Download() 71 const std::string &tableName, const std::string &gid, const DBValue &prefix, DBVBucket &assets) in RemoveLocalAssets() 73 for (auto &[key, value] : assets) { in RemoveLocalAssets() 34 Download( const std::string &tableName, const std::string &gid, const DBValue &prefix, DBVBucket &assets) Download() argument 70 RemoveLocalAssets( const std::string &tableName, const std::string &gid, const DBValue &prefix, DBVBucket &assets) RemoveLocalAssets() argument
|
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
H A D | raw_data_parser.h | 32 static size_t ParserRawData(const uint8_t *data, size_t length, Assets &assets); 33 static size_t ParserRawData(const uint8_t *data, size_t length, std::map<std::string, Asset> &assets); 38 static std::vector<uint8_t> PackageRawData(const Assets &assets); 39 static std::vector<uint8_t> PackageRawData(const std::map<std::string, Asset> &assets);
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
H A D | asset_loader.h | 26 const std::string &tableName, const std::string &gid, const Value &prefix, VBucket &assets); 28 const std::string &tableName, const std::string &gid, const Value &prefix, VBucket &assets);
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/c_adapter/ |
H A D | cloud_extension.rs | 114 /// Information needed when upload or download assets through CloudAssetLoader. 125 /// Upload assets, with table name, gid, and prefix. This function only mutably borrows 126 /// assets, so this pointer won't be taken by CloudAssetLoader. Users should free it if the hashmap of 127 /// assets is no longer in need. 134 assets: *mut OhCloudExtVector, 136 if loader.is_null() || info.is_null() || assets.is_null() { 154 let assets = match OhCloudExtVector::get_inner_ref(assets, SafetyCheckId::Vector) { 158 let assets = match assets { [all...] |