/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
H A D | cloud_sync_tag_assets.cpp | 21 void TagSingleAssetForDownload(AssetOpType flag, Asset &asset, Assets &res, int &errCode) in TagSingleAssetForDownload() 54 void TagSingleAssetForUpload(AssetOpType flag, Asset &asset, Assets &res) in TagSingleAssetForUpload() 87 Asset &asset, Assets &res, int &errCode) in TagAssetWithNormalStatus() 97 Assets &assets, Assets &res, int &errCode) in TagAssetsWithNormalStatus() 115 // When type of Assets is not Nil but a vector which size is 0, we think data is not contain this field. in IsDataContainField() 116 if (type.index() == TYPE_INDEX<Assets>) { in IsDataContainField() 117 if (std::get<Assets>(type).empty()) { in IsDataContainField() 127 void TagAssetWithSameHash(const bool isNormalStatus, Asset &beCoveredAsset, Asset &coveredAsset, Assets &res, in TagAssetWithSameHash() 137 std::pair<bool, Assets> TagForNotContainsAsse [all...] |
H A D | cloud_sync_utils.h | 48 static void StatusToFlagForAssets(Assets &assets);
92 static void FillAssetIdToAssetsData(const Assets &extend, Assets &assets);
|
H A D | cloud_syncer.h | 40 using DownloadCommitList = std::vector<std::tuple<std::string, std::map<std::string, Assets>, bool>>; 101 std::map<TableName, std::map<std::string, std::map<std::string, Assets>>> assetsInfo; 123 std::map<std::string, Assets> assets; 249 std::map<std::string, Assets> GetAssetsFromVBucket(VBucket &data); 251 std::map<std::string, Assets> TagAssetsInSingleRecord(VBucket &coveredData, VBucket &beCoveredData, 298 void SeparateNormalAndFailAssets(const std::map<std::string, Assets> &assetsMap, VBucket &normalAssets, 362 std::map<std::string, Assets> &downloadAssets); 367 std::map<std::string, Assets>& BackFillAssetsAfterDownload(int downloadCode, int deleteCode, 368 std::map<std::string, std::vector<uint32_t>> &tmpFlags, std::map<std::string, Assets> &tmpAssetsToDownload, 369 std::map<std::string, Assets> [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/ |
H A D | asset_operation_utils.h | 44 static AssetOperationUtils::AssetOpType DefaultOperation(const Asset &, const Assets &); 45 static AssetOperationUtils::AssetOpType CheckBeforeDownload(const Asset &cacheAsset, const Assets &dbAssets); 46 static AssetOperationUtils::AssetOpType CheckAfterDownload(const Asset &cacheAsset, const Assets &dbAssets); 48 const Assets &dbAssets); 49 static AssetOperationUtils::AssetOpType CheckAfterUpload(const Asset &cacheAsset, const Assets &dbAssets); 50 static AssetOperationUtils::AssetOpType HandleIfExistAndSameStatus(const Asset &cacheAsset, const Assets &dbAssets); 51 static Assets GetAssets(const std::string &colName, const VBucket &rowData); 52 static void MergeAssetFlag(const Assets &from, Asset &target); 53 static void MergeAssetsFlag(const Assets &from, Type &target);
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
H A D | distributeddb_cloud_asset_compare_test.cpp | 62 {FIELD_HOUSE, TYPE_INDEX<Asset>, false}, {FIELD_CARS, TYPE_INDEX<Assets>, false} 114 DATA_BASELINE = GenDatum(1, "Jack", a1, Assets({a2, a3, a4})); // id is 1 in GenData() 115 DATA_EMPTY_ASSET = GenDatum(2, "PoorGuy", a1, Assets({})); // id is 2 in GenData() 117 DATA_ASSET_SAME_NAME_BUT_CHANGE = GenDatum(3, "Alice", a1Changed, Assets({a2, a3, a4})); // id is 3 in GenData() 118 DATA_ASSETS_SAME_NAME_PARTIALLY_CHANGED = GenDatum(4, "David", a1, Assets({a2, a3Changed, a4})); // id is 4 in GenData() 119 DATA_ALL_SAME = GenDatum(5, "Marry", a1, Assets({a2, a3, a4})); // id is 5 in GenData() 120 DATA_ASSETS_MORE_FIELD = GenDatum(6, "Carl", a1, Assets({a2, a3, a4, a5})); // id is 6 in GenData() 121 DATA_ASSETS_DIFFERENT_FIELD = GenDatum(7, "Carllol", a1, Assets({a2, a3, a5})); // id is 7 in GenData() 122 DATA_ASSETS_DIFFERENT_CHANGED_FIELD = GenDatum(8, "Carllol", a1, Assets({a2, a3Changed, a5})); // id is 8 in GenData() 124 9, "Lob", a1Changed, Assets({a2Change in GenData() [all...] |
H A D | virtual_asset_loader.h | 22 using DownloadCallBack = std::function<void (std::map<std::string, Assets> &assets)>; 24 using RemoveLocalAssetsCallBack = std::function<void (std::map<std::string, Assets> &assets)>; 31 std::map<std::string, Assets> &assets) override; 36 std::map<std::string, Assets> &assets) override;
|
H A D | virtual_cloud_data_translate.h | 27 std::vector<uint8_t> AssetsToBlob(const Assets &assets) override; 29 Assets BlobToAssets(const std::vector<uint8_t> &blob) override;
|
H A D | virtual_cloud_data_translate.cpp | 36 uint32_t CalculateLens(const Assets &assets) in CalculateLens() 82 std::vector<uint8_t> VirtualCloudDataTranslate::AssetsToBlob(const Assets &assets) in AssetsToBlob() 103 Assets VirtualCloudDataTranslate::BlobToAssets(const std::vector<uint8_t> &blob) in BlobToAssets() 109 Assets assets; in BlobToAssets()
|
H A D | distributeddb_cloud_syncer_download_assets_test.cpp | 63 {COL_HEIGHT, TYPE_INDEX<double>}, {COL_ASSET, TYPE_INDEX<Asset>}, {COL_ASSETS, TYPE_INDEX<Assets>}, 66 {COL_HEIGHT, TYPE_INDEX<double>}, {COL_ASSET, TYPE_INDEX<Asset>}, {COL_ASSETS, TYPE_INDEX<Assets>}, 70 {COL_ASSETS, TYPE_INDEX<Assets>}, {COL_AGE, TYPE_INDEX<int64_t>, true}}; 98 const Assets ASSETS_COPY1 = { ASSET_COPY, ASSET_COPY2 }; 144 Assets assets; in GenerateDataRecords() 189 std::get<Assets>(vBucket[COL_ASSETS])); in InsertLocalData() 197 void UpdateLocalData(sqlite3 *&db, const std::string &tableName, const Assets &assets) in UpdateLocalData() 210 void UpdateLocalData(sqlite3 *&db, const std::string &tableName, const Assets &assets, int32_t begin, int32_t end) in UpdateLocalData() 330 void CheckDownloadForTest001(int index, map<std::string, Assets> &assets) in CheckDownloadForTest001() 352 ASSERT_EQ(SQLiteRelationalUtils::GetCloudValueByType(stmt, TYPE_INDEX<Assets>, in CheckDownloadFailedForTest002() [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/cloud/ |
H A D | asset_operation_utils.cpp | 25 using Reaction = std::function<AssetOperationUtils::AssetOpType (const Asset &, const Assets &)>; 50 } else if (TYPE_INDEX<Assets> == colData.index()) { in CalAssetOperation() 51 auto assets = std::get<Assets>(colData); in CalAssetOperation() 105 if (item.second.index() != TYPE_INDEX<Assets>) { in FilterDeleteAsset() 108 auto &assets = std::get<Assets>(item.second); in FilterDeleteAsset() 132 AssetOperationUtils::AssetOpType AssetOperationUtils::DefaultOperation(const Asset &, const Assets &) in DefaultOperation() 138 const Assets &dbAssets) in CheckBeforeDownload() 144 const Assets &dbAssets) in CheckAfterDownload() 150 const Assets &dbAssets) in CheckWithDownload() 173 AssetOperationUtils::AssetOpType AssetOperationUtils::CheckAfterUpload(const Asset &cacheAsset, const Assets [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
H A D | rdb_cloud_data_translate.h | 25 using Assets = DistributedDB::Assets; 27 using DataAssets = NativeRdb::ValueObject::Assets; 31 std::vector<uint8_t> AssetsToBlob(const Assets &assets) override; 33 Assets BlobToAssets(const std::vector<uint8_t> &blob) override;
|
H A D | rdb_asset_loader.cpp | 33 std::map<std::string, Assets> &assets) in Download() 49 DistributedData::VBucket deleteAssets = ValueProxy::Convert(std::map<std::string, Assets>{{ "", assets }}); in RemoveLocalAssets() 58 auto* downLoadAssets = Traits::get_if<DistributedData::Assets>(&asset.second); in PostEvent() 66 void RdbAssetLoader::PostEvent(DistributedData::AssetEvent eventId, DistributedData::Assets& assets, in PostEvent()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/common/ |
H A D | value_proxy.h | 85 class Assets { class in OHOS::DistributedData::final 87 Assets() = default; 88 Assets(Assets &&proxy) noexcept 92 Assets(const Assets &proxy) in Assets() function in OHOS::DistributedData::final::Assets 96 Assets(DistributedData::Assets assets); 97 Assets(CommonType::Assets asset [all...] |
H A D | value_proxy.cpp | 355 ValueProxy::Assets::Assets(DistributedData::Assets assets) in Assets() function in OHOS::DistributedData::ValueProxy::Assets 364 ValueProxy::Assets::Assets(NativeRdb::ValueObject::Assets assets) in Assets() function in OHOS::DistributedData::ValueProxy::Assets 373 ValueProxy::Assets::Assets(CommonType::Assets assets) in Assets() function in OHOS::DistributedData::ValueProxy::Assets 382 ValueProxy::Assets function in OHOS::DistributedData::ValueProxy::Assets [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
H A D | cloud_storage_utils.h | 66 static void FillAssetsAfterDownloadFail(Assets &assets, Assets &dbAssets, 68 static void MergeAssetWithFillFunc(Assets &assets, Assets &dbAssets, const std::map<std::string, 72 static void FillAssetsAfterDownload(Assets &assets, Assets &dbAssets, 75 static void FillAssetsBeforeUpload(Assets &assets, Assets &dbAssets, 78 static void FillAssetsForUpload(Assets &assets, Assets [all...] |
/foundation/graphic/graphic_3d/lume/Lume_3D/src/gltf/ |
H A D | data.h | 33 struct Assets { struct 34 Assets() = default; 35 Assets(const Assets& aOther) = delete; 36 virtual ~Assets() = default; 91 class Data : public Assets, public IGLTFData {
|
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
H A D | raw_data_parser.h | 26 using Assets = ValueObject::Assets; 32 static size_t ParserRawData(const uint8_t *data, size_t length, Assets &assets); 38 static std::vector<uint8_t> PackageRawData(const Assets &assets);
|
/foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/ |
H A D | value_object.h | 44 using Assets = std::vector<Asset>; 47 using Type = std::variant<Nil, int64_t, double, std::string, bool, Blob, Asset, Assets, FloatVector, BigInt>; 99 TYPE_ASSETS = TYPE_INDEX<Assets>, 219 * This constructor is used to convert the Assets input parameter to a value of type ValueObject. 221 * @param val Indicates an Assets input parameter. 223 API_EXPORT ValueObject(Assets val); 228 * This constructor is used to convert the Assets input parameter to a value of type ValueObject. 230 * @param val Indicates an Assets input parameter. 295 API_EXPORT int GetAssets(Assets &val) const; 356 API_EXPORT operator Assets() cons [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/service_impl/ |
H A D | types.rs | 49 Assets(Vec<ipc_conn::CloudAsset>), 54 matches!(self, Value::Asset(_) | Value::Assets(_)) 68 Value::Assets(a) => ipc_conn::FieldRaw::Assets(ipc_conn::CloudAssets(a.clone())), in from() 83 ipc_conn::FieldRaw::Assets(a) => Value::Assets(a.0.clone()), in from() 98 ipc_conn::FieldRaw::Assets(ref a) => Value::Assets(a.0.clone()), in from()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/cloud/ |
H A D | iAssetLoader.h | 32 std::map<std::string, Assets> &assets) in Download() 43 std::map<std::string, Assets> &assets) in RemoveLocalAssets()
|
H A D | icloud_data_translate.h | 31 virtual std::vector<uint8_t> AssetsToBlob(const Assets &assets) = 0; 33 virtual Assets BlobToAssets(const std::vector<uint8_t> &blob) = 0;
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
H A D | cloud_storage_utils.cpp | 128 Assets assets; in BindBlob() 174 } else if (field.type == TYPE_INDEX<Assets>) { in BindAsset() 175 Assets assets; in BindAsset() 275 Assets val; in BlobToVector() 302 if (item.type != TYPE_INDEX<Asset> && item.type != TYPE_INDEX<Assets>) { in GetCloudAsset() 351 if (type.index() != TYPE_INDEX<Asset> && type.index() != TYPE_INDEX<Assets>) { in GetAssetFieldsFromSchema() 379 Assets data = std::get<Assets>(item.second); in ObtainAssetFromVBucket() 431 Assets assets; in GetAssetFromAssets() 494 void CloudStorageUtils::FillAssetsAfterDownload(Assets [all...] |
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/common/ |
H A D | common_types.h | 49 using Assets = std::vector<AssetValue>;
50 using Value = std::variant<std::monostate, int64_t, double, std::string, bool, Bytes, Asset, Assets>;
|
/foundation/distributeddatamgr/relational_store/interfaces/inner_api/common_type/include/ |
H A D | common_types.h | 49 using Assets = std::vector<AssetValue>; 50 using Value = std::variant<std::monostate, int64_t, double, std::string, bool, Bytes, Asset, Assets>;
|
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
H A D | value_object.cpp | 86 ValueObject::ValueObject(ValueObject::Assets val) : value(std::move(val)) in ValueObject() 180 int ValueObject::GetAssets(Assets &val) const in GetAssets() 302 ValueObject::operator Assets() const in operator Assets() 304 auto val = std::get_if<Assets>(&value); in operator Assets() 375 result = Assets(*this) < Assets(rhs); in operator <()
|