/foundation/multimedia/media_library/frameworks/services/media_cloud_enhancement/src/utils/ |
H A D | enhancement_database_operations.cpp | 118 ValuesBucket assetInfo;
in InsertCloudEnhancementImageInDb() local 119 assetInfo.PutInt(MediaColumn::MEDIA_TYPE, fileAsset.GetMediaType());
in InsertCloudEnhancementImageInDb() 121 assetInfo.PutString(MediaColumn::MEDIA_MIME_TYPE,
in InsertCloudEnhancementImageInDb() 123 assetInfo.PutString(MediaColumn::MEDIA_FILE_PATH, fileAsset.GetPath());
in InsertCloudEnhancementImageInDb() 124 assetInfo.PutLong(MediaColumn::MEDIA_TIME_PENDING, fileAsset.GetTimePending());
in InsertCloudEnhancementImageInDb() 125 assetInfo.PutString(MediaColumn::MEDIA_NAME, displayName);
in InsertCloudEnhancementImageInDb() 126 assetInfo.PutString(MediaColumn::MEDIA_TITLE, MediaFileUtils::GetTitleFromDisplayName(displayName));
in InsertCloudEnhancementImageInDb() 127 assetInfo.PutString(MediaColumn::MEDIA_DEVICE_NAME, cmd.GetDeviceName());
in InsertCloudEnhancementImageInDb() 128 HandleDateAdded(nowTime, MEDIA_TYPE_PHOTO, assetInfo);
in InsertCloudEnhancementImageInDb() 131 assetInfo in InsertCloudEnhancementImageInDb() [all...] |
/foundation/filemanagement/dfs_service/interfaces/inner_api/native/cloudsync_kit_inner/ |
H A D | cloud_sync_common.h | 90 AssetInfoObj(const AssetInfo &assetInfo) in AssetInfoObj() 91 : uri(assetInfo.uri), in AssetInfoObj() 92 recordType(assetInfo.recordType), in AssetInfoObj() 93 recordId(assetInfo.recordId), in AssetInfoObj() 94 fieldKey(assetInfo.fieldKey), in AssetInfoObj() 95 assetName(assetInfo.assetName) in AssetInfoObj()
|
H A D | cloud_sync_asset_manager.h | 49 * @param assetInfo 下载文件信息 52 virtual int32_t DownloadFile(const int32_t userId, const std::string &bundleName, AssetInfo &assetInfo) = 0; 58 * @param assetInfo 下载文件信息 64 AssetInfo &assetInfo, 71 * @param assetInfo 下载批量文件信息 77 const std::vector<AssetInfo> &assetInfo,
|
/foundation/filemanagement/dfs_service/frameworks/native/cloudsync_kit_inner/src/ |
H A D | cloud_sync_asset_manager_impl.cpp | 50 AssetInfo &assetInfo) in DownloadFile() 59 AssetInfoObj assetInfoObj(assetInfo); in DownloadFile() 67 const std::vector<AssetInfo> &assetInfo, in DownloadFiles() 78 for (const auto &info : assetInfo) { in DownloadFiles() 90 AssetInfo &assetInfo, in DownloadFile() 117 AssetInfoObj assetInfoObj(assetInfo); in DownloadFile() 48 DownloadFile(const int32_t userId, const std::string &bundleName, AssetInfo &assetInfo) DownloadFile() argument 65 DownloadFiles(const int32_t userId, const std::string &bundleName, const std::vector<AssetInfo> &assetInfo, std::vector<bool> &assetResultMap) DownloadFiles() argument 87 DownloadFile(const int32_t userId, const std::string &bundleName, const std::string &networkId, AssetInfo &assetInfo, ResultCallback resultCallback) DownloadFile() argument
|
/foundation/filemanagement/dfs_service/test/unittests/cloudsync_api/cloudsync_impl/ |
H A D | cloud_sync_asset_manager_impl_test.cpp | 93 AssetInfo assetInfo; in HWTEST_F() local 94 int32_t res = CloudSyncAssetManagerImpl::GetInstance().DownloadFile(userId, bundleName, assetInfo); in HWTEST_F() 116 AssetInfo assetInfo; in HWTEST_F() local 119 bundleName, networkId, assetInfo, resultCallback); in HWTEST_F() 140 std::vector<AssetInfo> assetInfo; in HWTEST_F() local 143 bundleName, assetInfo, assetResultMap); in HWTEST_F()
|
H A D | cloud_sync_asset_manager_impl_unnomal_test.cpp | 86 AssetInfo assetInfo; in HWTEST_F() local 87 int32_t ret = assetManager.DownloadFile(userId, request, assetInfo); in HWTEST_F()
|
H A D | cloud_sync_common_test.cpp | 558 AssetInfoObj assetInfo; in HWTEST_F() local 560 auto res = assetInfo.ReadFromParcel(parcel); in HWTEST_F() 579 AssetInfoObj assetInfo; in HWTEST_F() local 581 auto res = assetInfo.Marshalling(parcel); in HWTEST_F() 600 auto assetInfo = make_shared<AssetInfoObj>(); in HWTEST_F() local 602 auto res = assetInfo->Unmarshalling(parcel); in HWTEST_F()
|
/foundation/filemanagement/dfs_service/test/fuzztest/cloudsyncassetmanager_fuzzer/ |
H A D | cloudsyncassetmanager_fuzzer.cpp | 50 AssetInfo assetInfo = { in DownloadFileFuzzTest() local 58 CloudSyncAssetManager::GetInstance().DownloadFile(userId, bundleName, assetInfo); in DownloadFileFuzzTest() 69 AssetInfo assetInfo = { in DownloadFilesFuzzTest() local 77 assetInfos.emplace_back(assetInfo); in DownloadFilesFuzzTest() 94 AssetInfo assetInfo = { in DownloadFileCallbackFuzzTest() local 102 CloudSyncAssetManager::GetInstance().DownloadFile(userId, bundleName, networkId, assetInfo, callback); in DownloadFileCallbackFuzzTest()
|
/foundation/filemanagement/dfs_service/frameworks/native/cloudsync_kit_inner/include/ |
H A D | cloud_sync_asset_manager_impl.h | 33 int32_t DownloadFile(const int32_t userId, const std::string &bundleName, AssetInfo &assetInfo) override; 38 AssetInfo &assetInfo, 42 const std::vector<AssetInfo> &assetInfo,
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
H A D | distributeddb_cloud_meta_data_test.cpp | 240 VBucket assetInfo; in HWTEST_F() local 242 EXPECT_EQ(proxyObj.GetInfoByPrimaryKeyOrGid(TABLE_NAME_1, assetInfo, log, assetInfo), in HWTEST_F() 244 EXPECT_EQ(proxyObj.FillCloudAssetForDownload(TABLE_NAME_1, assetInfo, true), -E_INVALID_DB); in HWTEST_F() 246 std::pair<int, uint32_t> res = proxyObj.GetAssetsByGidOrHashKey(TABLE_NAME_1, "", hashKey, assetInfo); in HWTEST_F() 343 VBucket assetInfo; in HWTEST_F() local 345 EXPECT_EQ(obj.GetInfoByPrimaryKeyOrGid(TABLE_NAME_1, assetInfo, log, assetInfo), -E_INVALID_DB); in HWTEST_F() 346 EXPECT_EQ(obj.FillCloudAssetForDownload(TABLE_NAME_1, assetInfo, true), -E_INVALID_DB); in HWTEST_F()
|
H A D | distributeddb_cloud_save_cloud_data_test.cpp | 285 VBucket assetInfo; in GetInfoByPrimaryKeyOrGidTest() local 286 EXPECT_EQ(storageProxy->GetInfoByPrimaryKeyOrGid(g_tableName, vBucket, dataInfoWithLog, assetInfo), expectCode); in GetInfoByPrimaryKeyOrGidTest() 467 VBucket assetInfo; in VbucketWithoutPrimaryDataTest() local 468 EXPECT_EQ(storageProxy->GetInfoByPrimaryKeyOrGid(g_tableName, vBucket, dataInfoWithLog, assetInfo), E_OK); in VbucketWithoutPrimaryDataTest() 548 VBucket assetInfo; in PrimaryKeyCollateTest() local 549 EXPECT_EQ(storageProxy->GetInfoByPrimaryKeyOrGid(g_tableName, vBucket, dataInfoWithLog, assetInfo), expectCode); in PrimaryKeyCollateTest()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
H A D | object_asset_loader.cpp | 41 AssetInfo assetInfo; in Transfer() local 42 assetInfo.uri = asset.uri; in Transfer() 43 assetInfo.assetName = asset.name; in Transfer() 45 DistributedData::Anonymous::Change(deviceId).c_str(), assetInfo.assetName.c_str()); in Transfer() 47 auto res = CloudSyncAssetManager::GetInstance().DownloadFile(userId, bundleName, deviceId, assetInfo, in Transfer() 63 DistributedData::Anonymous::Change(deviceId).c_str(), assetInfo.assetName.c_str()); in Transfer()
|
/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
H A D | medialibrary_object_utils.cpp | 154 ValuesBucket assetInfo; in InsertFileInDb() local 155 assetInfo.PutInt(MEDIA_DATA_DB_MEDIA_TYPE, fileAsset.GetMediaType()); in InsertFileInDb() 156 assetInfo.PutString(MEDIA_DATA_DB_URI, MediaFileUtils::GetMediaTypeUri(fileAsset.GetMediaType())); in InsertFileInDb() 158 assetInfo.PutString(MEDIA_DATA_DB_MIME_TYPE, MimeTypeUtils::GetMimeTypeFromExtension(extension)); in InsertFileInDb() 159 assetInfo.PutString(MEDIA_DATA_DB_RELATIVE_PATH, fileAsset.GetRelativePath()); in InsertFileInDb() 160 assetInfo.PutString(MEDIA_DATA_DB_NAME, displayName); in InsertFileInDb() 161 assetInfo.PutString(MEDIA_DATA_DB_TITLE, MediaFileUtils::GetTitleFromDisplayName(displayName)); in InsertFileInDb() 164 assetInfo.PutLong(MEDIA_DATA_DB_SIZE, statInfo.st_size); in InsertFileInDb() 165 assetInfo.PutLong(MEDIA_DATA_DB_DATE_ADDED, MediaFileUtils::UTCTimeMilliSeconds()); in InsertFileInDb() 166 assetInfo in InsertFileInDb() [all...] |
H A D | medialibrary_asset_operations.cpp | 879 ValuesBucket assetInfo; in FillAssetInfo() local 880 assetInfo.PutInt(MediaColumn::MEDIA_TYPE, fileAsset.GetMediaType()); in FillAssetInfo() 882 assetInfo.PutString(MediaColumn::MEDIA_MIME_TYPE, in FillAssetInfo() 884 assetInfo.PutString(MediaColumn::MEDIA_FILE_PATH, fileAsset.GetPath()); in FillAssetInfo() 886 assetInfo.PutString(MediaColumn::MEDIA_RELATIVE_PATH, in FillAssetInfo() 888 assetInfo.PutString(MediaColumn::MEDIA_VIRTURL_PATH, in FillAssetInfo() 891 assetInfo.PutLong(MediaColumn::MEDIA_TIME_PENDING, fileAsset.GetTimePending()); in FillAssetInfo() 893 assetInfo.PutString(MediaColumn::MEDIA_NAME, displayName); in FillAssetInfo() 894 assetInfo.PutString(MediaColumn::MEDIA_TITLE, in FillAssetInfo() 897 assetInfo in FillAssetInfo() [all...] |
/foundation/filemanagement/dfs_service/test/fuzztest/cloudsyncservicestub_fuzzer/ |
H A D | cloudsyncservicestub_fuzzer.cpp | 197 AssetInfo assetInfo = {.uri = fuzzData.GetStringFromData(pos), in HandleDownloadFileFuzzTest() local 202 AssetInfoObj assetInfoObj(assetInfo); in HandleDownloadFileFuzzTest() 556 AssetInfo assetInfo = {.uri = fuzzData.GetStringFromData(len), in HandleDownloadFilesFuzzTest() local 561 AssetInfoObj assetInfoObj(assetInfo); in HandleDownloadFilesFuzzTest() 594 AssetInfo assetInfo = {.uri = fuzzData.GetStringFromData(len), in HandleDownloadAssetFuzzTest() local 599 AssetInfoObj assetInfoObj(assetInfo); in HandleDownloadAssetFuzzTest()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 35 const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) in GetInfoByPrimaryKeyOrGid() 70 errCode = GetInfoByStatement(selectStmt, assetFields, pkMap, dataInfoWithLog, assetInfo); in GetInfoByPrimaryKeyOrGid() 112 VBucket &assetInfo) in GetInfoByStatement() 114 int index = GetLogInfoByStatement(statement, dataInfoWithLog.logInfo); // start index of assetInfo or primary key in GetInfoByStatement() 122 errCode = PutVBucketByType(assetInfo, field, cloudValue); in GetInfoByStatement() 1279 const VBucket &vBucket, const Field &field, VBucket &assetInfo) in IsNeedUpdateAssetIdInner() 1284 Asset *assetDBPtr = std::get_if<Asset>(&assetInfo[field.colName]); in IsNeedUpdateAssetIdInner() 1296 Assets *assetsDBPtr = std::get_if<Assets>(&assetInfo[field.colName]); in IsNeedUpdateAssetIdInner() 1349 VBucket assetInfo; in IsNeedUpdateAssetId() local 1350 errCode = GetAssetInfoOnTable(selectStmt, assetFields, assetInfo); in IsNeedUpdateAssetId() 34 GetInfoByPrimaryKeyOrGid(const TableSchema &tableSchema, const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) GetInfoByPrimaryKeyOrGid() argument 110 GetInfoByStatement(sqlite3_stmt *statement, const std::vector<Field> &assetFields, const std::map<std::string, Field> &pkMap, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) GetInfoByStatement() argument 1278 IsNeedUpdateAssetIdInner(sqlite3_stmt *selectStmt, const VBucket &vBucket, const Field &field, VBucket &assetInfo) IsNeedUpdateAssetIdInner() argument 1577 GetAssetInfoOnTable(sqlite3_stmt *&stmt, const std::vector<Field> &assetFields, VBucket &assetInfo) GetAssetInfoOnTable() argument [all...] |
H A D | sqlite_single_ver_relational_storage_executor.h | 132 DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo); 316 const std::map<std::string, Field> &pkMap, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo); 434 int GetAssetInfoOnTable(sqlite3_stmt *&stmt, const std::vector<Field> &assetFields, VBucket &assetInfo); 445 VBucket &assetInfo);
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | distributeddb_relational_cloud_syncable_storage_test.cpp | 1002 VBucket assetInfo; in HWTEST_F() local 1004 ASSERT_EQ(g_storageProxy->GetInfoByPrimaryKeyOrGid(g_tableName, vBucket, dataInfo, assetInfo), E_OK); in HWTEST_F() 1006 auto entry1 = assetInfo.find("assert"); in HWTEST_F() 1007 auto entry2 = assetInfo.find("asserts"); in HWTEST_F() 1008 ASSERT_NE(entry1, assetInfo.end()); in HWTEST_F() 1009 ASSERT_NE(entry2, assetInfo.end()); in HWTEST_F() 1040 VBucket assetInfo; in HWTEST_F() local 1042 ASSERT_EQ(g_storageProxy->GetInfoByPrimaryKeyOrGid(g_tableName, vBucket, dataInfo, assetInfo), E_OK); in HWTEST_F() 1044 EXPECT_EQ(assetInfo.size(), 0u); in HWTEST_F()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | sqlite_cloud_kv_store.h | 63 VBucket &assetInfo) override;
|
H A D | sqlite_cloud_kv_store.cpp | 240 DataInfoWithLog &dataInfoWithLog, [[gnu::unused]] VBucket &assetInfo) in GetInfoByPrimaryKeyOrGid() 239 GetInfoByPrimaryKeyOrGid([[gnu::unused]] const std::string &tableName, const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, [[gnu::unused]] VBucket &assetInfo) GetInfoByPrimaryKeyOrGid() argument
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
H A D | relational_sync_able_storage.h | 170 DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) override; 232 const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo);
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
H A D | icloud_sync_storage_interface.h | 129 DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) = 0;
|
H A D | storage_proxy.h | 81 DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo);
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
H A D | storage_proxy.cpp | 278 DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) in GetInfoByPrimaryKeyOrGid() 289 int errCode = store_->GetInfoByPrimaryKeyOrGid(tableName, vBucket, dataInfoWithLog, assetInfo); in GetInfoByPrimaryKeyOrGid() 295 assetInfo.clear(); in GetInfoByPrimaryKeyOrGid() 277 GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) GetInfoByPrimaryKeyOrGid() argument
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
H A D | relational_sync_able_storage.cpp | 1252 DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) in GetInfoByPrimaryKeyOrGid() 1259 return GetInfoByPrimaryKeyOrGidInner(transactionHandle_, tableName, vBucket, dataInfoWithLog, assetInfo); in GetInfoByPrimaryKeyOrGid() 1263 const std::string &tableName, const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) in GetInfoByPrimaryKeyOrGidInner() 1276 return handle->GetInfoByPrimaryKeyOrGid(tableSchema, vBucket, dataInfoWithLog, assetInfo); in GetInfoByPrimaryKeyOrGidInner() 1820 VBucket assetInfo; in UpsertDataInTransaction() local 1826 errCode = GetInfoByPrimaryKeyOrGidInner(handle, tableName, record, dataInfoWithLog, assetInfo); in UpsertDataInTransaction() 1251 GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) GetInfoByPrimaryKeyOrGid() argument 1262 GetInfoByPrimaryKeyOrGidInner(SQLiteSingleVerRelationalStorageExecutor *handle, const std::string &tableName, const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) GetInfoByPrimaryKeyOrGidInner() argument
|