/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/snapshot/ |
H A D | snapshot.h | 29 virtual int32_t Transferred(Asset& asset) = 0; 31 virtual int32_t Upload(Asset& asset) = 0; 33 virtual int32_t Download(Asset& asset) = 0; 35 virtual int32_t Uploaded(Asset& asset) = 0; 37 virtual int32_t Downloaded(Asset& asset) = 0; 39 virtual TransferStatus GetAssetStatus(Asset& asset) = 0; 41 virtual int32_t BindAsset(const Asset& asset, const AssetBindInfo& bindInfo, const StoreInfo& storeInfo) = 0; 43 virtual int32_t OnDataChanged(Asset& asset, const std::string &deviceId) = 0; 45 virtual bool IsBoundAsset(const Asset& asset) = 0;
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
H A D | object_snapshot.h | 30 int32_t Upload(Asset& asset) override; 31 int32_t Download(Asset& asset) override; 32 TransferStatus GetAssetStatus(Asset& asset) override; 33 int32_t Uploaded(Asset& asset) override; 34 int32_t Downloaded(Asset& asset) override; 35 int32_t Transferred(Asset& asset) override; 36 int32_t OnDataChanged(Asset& asset, const std::string& deviceId) override; 37 int32_t BindAsset(const Asset& asset, const DistributedData::AssetBindInfo& bindInfo, 39 bool IsBoundAsset(const Asset& asset) override;
|
H A D | object_asset_machine.cpp | 40 static int32_t DoTransfer(int32_t eventId, ChangedAssetInfo& changedAsset, Asset& asset, 41 const std::pair<std::string, Asset>& newAsset); 43 static int32_t ChangeAssetToNormal(int32_t eventId, ChangedAssetInfo& changedAsset, Asset& asset, 44 const std::pair<std::string, Asset>& newAsset); 46 static int32_t CompensateSync(int32_t eventId, ChangedAssetInfo& changedAsset, Asset& asset, 47 const std::pair<std::string, Asset>& newAsset); 49 static int32_t CompensateTransferring(int32_t eventId, ChangedAssetInfo& changedAsset, Asset& asset, 50 const std::pair<std::string, Asset>& newAsset); 52 static int32_t SaveNewAsset(int32_t eventId, ChangedAssetInfo& changedAsset, Asset& asset, 53 const std::pair<std::string, Asset> [all...] |
H A D | object_asset_machine.h | 29 DistributedData::Asset asset; 34 ChangedAssetInfo(const Asset& bindAsset, const AssetBindInfo& assetBindInfo, const StoreInfo& store) in ChangedAssetInfo() 43 (int32_t eventId, ChangedAssetInfo& changedAsset, Asset& asset, const std::pair<std::string, Asset>& newAsset); 55 static int32_t DFAPostEvent(AssetEvent eventId, ChangedAssetInfo& changedAsset, Asset& asset, 56 const std::pair<std::string, Asset>& newAsset = std::pair<std::string, Asset>());
|
H A D | object_snapshot.cpp | 26 int32_t ObjectSnapshot::Upload(Asset& asset) in Upload() 34 bool ObjectSnapshot::IsBoundAsset(const Asset& asset) in IsBoundAsset() 43 int32_t ObjectSnapshot::Download(Asset& asset) in Download() 51 TransferStatus ObjectSnapshot::GetAssetStatus(Asset& asset) in GetAssetStatus() 59 int32_t ObjectSnapshot::Uploaded(Asset& asset) in Uploaded() 67 int32_t ObjectSnapshot::Downloaded(Asset& asset) in Downloaded() 75 int32_t ObjectSnapshot::OnDataChanged(Asset& asset, const std::string& deviceId) in OnDataChanged() 80 std::pair<std::string, Asset> newAsset{ deviceId, asset }; in OnDataChanged() 84 int32_t ObjectSnapshot::BindAsset(const Asset& asset, const DistributedData::AssetBindInfo& bindInfo, in BindAsset() 88 ZLOGD("Asset i in BindAsset() [all...] |
H A D | object_asset_loader.h | 47 const DistributedData::Asset& asset); 49 const std::vector<DistributedData::Asset>& assets, const TransferFunc& callback); 58 bool IsDownloading(const DistributedData::Asset& asset); 59 bool IsDownloaded(const DistributedData::Asset& asset); 60 void UpdateDownloaded(const DistributedData::Asset& asset);
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/snapshot/ |
H A D | snapshot.cpp | 19 int32_t Snapshot::Upload(OHOS::DistributedData::Asset& asset) in Upload() 24 int32_t Snapshot::Download(OHOS::DistributedData::Asset& asset) in Download() 28 int32_t Snapshot::Uploaded(Asset& asset) in Uploaded() 32 int32_t Snapshot::Downloaded(Asset& asset) in Downloaded() 37 int32_t Snapshot::Transferred(Asset& asset) in Transferred() 42 TransferStatus Snapshot::GetAssetStatus(Asset& asset) in GetAssetStatus() 47 int32_t Snapshot::BindAsset(const Asset& asset, const AssetBindInfo& bindInfo, const StoreInfo& storeInfo) in BindAsset() 52 int32_t Snapshot::OnDataChanged(Asset& asset, const std::string &deviceId) in OnDataChanged() 57 bool Snapshot::IsBoundAsset(const Asset& asset) in IsBoundAsset()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
H A D | value_proxy_test.cpp | 137 DistributedDB::Asset dbAsset0 { .name = "dbname", .uri = "dburi" }; in HWTEST_F() 138 DistributedDB::Asset dbAsset1 { .name = "dbname", .uri = "dburi" }; in HWTEST_F() 139 std::map<std::string, DistributedDB::Asset> dbMap { { "asset0", dbAsset0 }, { "asset1", dbAsset1 } }; in HWTEST_F() 142 auto asset = std::get<OHOS::DistributedData::Asset>(transferredAsset.find("asset0")->second); in HWTEST_F() 164 using NormalAsset = OHOS::DistributedData::Asset; in HWTEST_F() 171 auto asset = std::get<DistributedDB::Asset>(transferredAsset.find("asset0")->second); in HWTEST_F() 200 auto asset = std::get<OHOS::DistributedData::Asset>(transferredAsset.find("asset0")->second); in HWTEST_F() 224 using NormalAsset = OHOS::DistributedData::Asset; in HWTEST_F() 252 * @tc.desc: Asset::ConvertToDataStatus function test. 259 DistributedDB::Asset asse in HWTEST_F() [all...] |
H A D | object_asset_machine_test.cpp | 38 Asset asset_; 50 Asset asset{ in SetUp() 96 Asset asset{ in HWTEST_F() 103 std::pair<std::string, Asset> changedAsset{ "device_2", asset }; in HWTEST_F() 120 Asset asset{ in HWTEST_F() 127 std::pair<std::string, Asset> changedAsset{ "device_2", asset }; in HWTEST_F() 142 Asset asset{ in HWTEST_F() 149 std::pair<std::string, Asset> changedAsset{ "device_2", asset }; in HWTEST_F() 166 Asset asset{ in HWTEST_F() 173 std::pair<std::string, Asset> changedAsse in HWTEST_F() [all...] |
/foundation/multimedia/player_framework/frameworks/native/video_editor/data_center/asset/ |
H A D | asset.cpp | 22 Asset::Asset(int64_t id, AssetType type, int fd) : id_(id), type_(type), fd_(fd) {} in Asset() function in OHOS::Media::Asset 24 uint64_t Asset::GetId() const in GetId() 29 int Asset::GetFd() const in GetFd() 34 AssetType Asset::GetType() const in GetType()
|
H A D | asset.h | 32 class Asset { class 34 Asset(int64_t id, AssetType type, int fd); 35 virtual ~Asset() = default;
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/common/ |
H A D | value_proxy.cpp | 180 ValueProxy::Asset::Asset(DistributedData::Asset asset) in Asset() function in OHOS::DistributedData::ValueProxy::Asset 185 ValueProxy::Asset::Asset(NativeRdb::AssetValue asset) in Asset() function in OHOS::DistributedData::ValueProxy::Asset 187 asset_ = DistributedData::Asset { .version = asset.version, in Asset() 200 ValueProxy::Asset::Asset(CommonType::AssetValue asset) in Asset() function in OHOS::DistributedData::ValueProxy::Asset 202 asset_ = DistributedData::Asset { .version = asset.version, in Asset() 215 ValueProxy::Asset function in OHOS::DistributedData::ValueProxy::Asset [all...] |
H A D | common_types_utils.h | 21 using Asset = OHOS::CommonType::Asset; 23 bool Marshalling(const Asset &input, MessageParcel &data); 25 bool Unmarshalling(Asset &output, MessageParcel &data);
|
H A D | value_proxy.h | 47 class Asset { class in OHOS::DistributedData::final 49 Asset() = default; 50 Asset(Asset &&proxy) noexcept 54 Asset(const Asset &proxy) in Asset() function in OHOS::DistributedData::final::Asset 58 Asset(DistributedData::Asset asset); 59 Asset(CommonType::AssetValue asset); 60 Asset(NativeRd [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/ |
H A D | asset_operation_utils.h | 37 static AssetOperationUtils::AssetOpType CalAssetOperation(const std::string &colName, const Asset &cacheAsset, 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); 47 static AssetOperationUtils::AssetOpType CheckWithDownload(bool before, const Asset &cacheAsset, 49 static AssetOperationUtils::AssetOpType CheckAfterUpload(const Asset &cacheAsset, const Assets &dbAssets); 50 static AssetOperationUtils::AssetOpType HandleIfExistAndSameStatus(const Asset &cacheAsset, const Assets &dbAssets); 52 static void MergeAssetFlag(const Assets &from, Asset &target);
|
/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() 99 for (Asset &asset : assets) { in TagAssetsWithNormalStatus() 127 void TagAssetWithSameHash(const bool isNormalStatus, Asset &beCoveredAsset, Asset &coveredAsset, Assets &res, in TagAssetWithSameHash() 175 for (Asset &beCoveredAsset : beCovered) { in TagAssets() 182 Asset &coveredAsset = covered[it->second]; in TagAssets() 212 static void TagCoveredAssetInner(Asset &covered, const Asset [all...] |
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/common/ |
H A D | object_types_util.h | 24 using Asset = OHOS::ObjectStore::Asset; 31 bool Marshalling(const Asset &input, MessageParcel &data); 33 bool Unmarshalling(Asset &output, MessageParcel &data);
|
/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 &)>; 47 if (TYPE_INDEX<Asset> == colData.index()) { in CalAssetOperation() 48 auto asset = std::get<Asset>(colData); in CalAssetOperation() 61 const Asset &cacheAsset, const VBucket &dbAssets, const AssetOperationUtils::CloudSyncAction &action) in CalAssetOperation() 97 if (item.second.index() == TYPE_INDEX<Asset>) { in FilterDeleteAsset() 98 auto &asset = std::get<Asset>(item.second); in FilterDeleteAsset() 132 AssetOperationUtils::AssetOpType AssetOperationUtils::DefaultOperation(const Asset &, const Assets &) in DefaultOperation() 137 AssetOperationUtils::AssetOpType AssetOperationUtils::CheckBeforeDownload(const Asset &cacheAsset, in CheckBeforeDownload() 143 AssetOperationUtils::AssetOpType AssetOperationUtils::CheckAfterDownload(const Asset &cacheAsset, in CheckAfterDownload() 149 AssetOperationUtils::AssetOpType AssetOperationUtils::CheckWithDownload(bool before, const Asset [all...] |
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
H A D | raw_data_parser.h | 25 using Asset = ValueObject::Asset; 31 static size_t ParserRawData(const uint8_t *data, size_t length, Asset &asset); 33 static size_t ParserRawData(const uint8_t *data, size_t length, std::map<std::string, Asset> &assets); 37 static std::vector<uint8_t> PackageRawData(const Asset &asset); 39 static std::vector<uint8_t> PackageRawData(const std::map<std::string, Asset> &assets); 45 Asset &asset_; 46 explicit InnerAsset(Asset &asset) : asset_(asset) {} in InnerAsset()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
H A D | rdb_cloud_data_translate.h | 24 using Asset = DistributedDB::Asset; 26 using DataAsset = NativeRdb::ValueObject::Asset; 30 std::vector<uint8_t> AssetToBlob(const Asset &asset) override; 32 Asset BlobToAsset(const std::vector<uint8_t> &blob) override;
|
H A D | rdb_asset_loader.h | 29 using Asset = DistributedDB::Asset; 38 std::map<std::string, std::vector<Asset>> &assets) override; 40 DBStatus RemoveLocalAssets(const std::vector<Asset> &assets) override;
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
H A D | cloud_storage_utils.h | 64 static int FillAssetBeforeDownload(Asset &asset); 65 static int FillAssetAfterDownloadFail(Asset &asset, Asset &dbAsset, AssetOperationUtils::AssetOpType assetOpType); 70 std::function<int(Asset &, Asset &, AssetOperationUtils::AssetOpType)> fillAsset); 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 [all...] |
/foundation/distributeddatamgr/relational_store/frameworks/js/napi/rdb/include/ |
H A D | napi_rdb_js_utils.h | 24 using Asset = OHOS::NativeRdb::AssetValue; 29 int32_t Convert2Value(napi_env env, napi_value input, Asset &output); 31 napi_value Convert2JSValue(napi_env env, const Asset &value);
|
/foundation/arkui/ace_engine/frameworks/base/resource/ |
H A D | asset_manager.h | 31 class Asset : public Referenced { class 33 ~Asset() override = default; 67 virtual RefPtr<Asset> GetAsset(const std::string& assetName) = 0; 69 virtual std::vector<RefPtr<Asset>> GetAssetFromI18n(const std::string& assetName) = 0;
|
/foundation/arkui/ace_engine/test/unittest/core/common/asset/ |
H A D | mock_asset.h | 23 class MockAsset final : public Asset { 41 MOCK_METHOD(RefPtr<Asset>, GetAsset, (const std::string& assetName)); 50 MOCK_METHOD(RefPtr<Asset>, GetAsset, (const std::string& assetName), (override)); 51 MOCK_METHOD(std::vector<RefPtr<Asset>>, GetAssetFromI18n, (const std::string& assetName), (override));
|