/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | sqlite_single_ver_storage_executor_cache.cpp | 92 DataItem dataItem; in RemoveDeviceDataInCacheMode() local 93 dataItem.key = REMOVE_DEVICE_DATA_KEY; in RemoveDeviceDataInCacheMode() 94 dataItem.value = devVect; in RemoveDeviceDataInCacheMode() 96 dataItem.flag = DataItem::REMOVE_DEVICE_DATA_NOTIFY_FLAG; in RemoveDeviceDataInCacheMode() 98 dataItem.flag = DataItem::REMOVE_DEVICE_DATA_FLAG; in RemoveDeviceDataInCacheMode() 109 errCode = BindSyncDataInCacheMode(statement, dataItem, hashKey, recordVersion); in RemoveDeviceDataInCacheMode() 154 int SQLiteSingleVerStorageExecutor::MigrateRmDevData(const DataItem &dataItem) const in MigrateRmDevData() 156 if (dataItem.key != REMOVE_DEVICE_DATA_KEY) { in MigrateRmDevData() 163 sql = dataItem.value.empty() ? REMOVE_ALL_DEV_DATA_SQL : REMOVE_DEV_DATA_SQL; in MigrateRmDevData() 165 sql = dataItem in MigrateRmDevData() 257 MigrateDataItem(DataItem &dataItem, const NotifyMigrateSyncData &syncData) MigrateDataItem() argument 502 BindSyncDataInCacheMode(sqlite3_stmt *statement, const DataItem &dataItem, const Key &hashKey, uint64_t recordVersion) const BindSyncDataInCacheMode() argument 595 GetExpandedCheckSql(QueryObject query, DataItem &dataItem) GetExpandedCheckSql() argument 629 SaveSyncDataItemInCacheMode(DataItem &dataItem, const DeviceInfo &deviceInfo, Timestamp &maxStamp, uint64_t recordVersion, const QueryObject &query) SaveSyncDataItemInCacheMode() argument 666 SaveSyncDataToCacheDatabase(const DataItem &dataItem, const Key &hashKey, uint64_t recordVersion) const SaveSyncDataToCacheDatabase() argument 752 PutIntoConflictAndCommitForMigrateCache(DataItem &dataItem, const DeviceInfo &deviceInfo, NotifyConflictAndObserverData ¬ify, bool isPermitForceWrite) PutIntoConflictAndCommitForMigrateCache() argument [all...] |
H A D | sqlite_cloud_kv_executor_utils.cpp | 532 const DataItem &dataItem) in BindOnlyUpdateLogStmt() 540 errCode = SQLiteUtils::BindBlobToStatement(logStmt, ++index, dataItem.hashKey); in BindOnlyUpdateLogStmt() 544 errCode = SQLiteUtils::BindTextToStatement(logStmt, ++index, dataItem.gid); in BindOnlyUpdateLogStmt() 549 errCode = SQLiteUtils::BindTextToStatement(logStmt, ++index, dataItem.version); in BindOnlyUpdateLogStmt() 554 errCode = SQLiteUtils::BindTextToStatement(logStmt, ++index, dataItem.gid); in BindOnlyUpdateLogStmt() 559 errCode = SQLiteUtils::BindTextToStatement(logStmt, ++index, dataItem.version); in BindOnlyUpdateLogStmt() 570 auto [errCode, dataItem] = GetDataItem(index, downloadData); in BindStmt() 576 return BindInsertStmt(logStmt, dataStmt, downloadData.user, dataItem); in BindStmt() 578 return BindUpdateStmt(logStmt, dataStmt, downloadData.user, dataItem); in BindStmt() 580 dataItem in BindStmt() 531 BindOnlyUpdateLogStmt(sqlite3_stmt *logStmt, const std::string &user, const DataItem &dataItem) BindOnlyUpdateLogStmt() argument 589 BindInsertStmt(sqlite3_stmt *logStmt, sqlite3_stmt *dataStmt, const std::string &user, const DataItem &dataItem) BindInsertStmt() argument 599 BindInsertLogStmt(sqlite3_stmt *logStmt, const std::string &user, const DataItem &dataItem) BindInsertLogStmt() argument 629 BindUpdateStmt(sqlite3_stmt *logStmt, sqlite3_stmt *dataStmt, const std::string &user, const DataItem &dataItem) BindUpdateStmt() argument 643 BindUpdateLogStmt(sqlite3_stmt *logStmt, const std::string &user, const DataItem &dataItem) BindUpdateLogStmt() argument 674 BindDeleteStmt(sqlite3_stmt *logStmt, sqlite3_stmt *dataStmt, const std::string &user, DataItem &dataItem) BindDeleteStmt() argument 691 BindDataStmt(sqlite3_stmt *dataStmt, const DataItem &dataItem, bool isInsert) BindDataStmt() argument 711 BindSyncDataStmt(sqlite3_stmt *dataStmt, const DataItem &dataItem, bool isInsert, int &index) BindSyncDataStmt() argument 761 BindCloudDataStmt(sqlite3_stmt *dataStmt, const DataItem &dataItem, int &index) BindCloudDataStmt() argument 878 DataItem dataItem; FillCloudGid() local 1426 BindFillGidLogStmt(sqlite3_stmt *logStmt, const std::string &user, const DataItem &dataItem, const VBucket &uploadExtend, const CloudWaterType &type) BindFillGidLogStmt() argument [all...] |
H A D | sqlite_single_ver_storage_executor.h | 59 int SaveSyncDataItem(DataItem &dataItem, const DeviceInfo &deviceInfo, 138 int PutLocalDataToCacheDB(const LocalDataItem &dataItem) const; 140 int SaveSyncDataItemInCacheMode(DataItem &dataItem, const DeviceInfo &deviceInfo, Timestamp &maxStamp, 230 int BindSavedSyncData(sqlite3_stmt *statement, const DataItem &dataItem, const Key &hashKey, 233 static int BindDevForSavedSyncData(sqlite3_stmt *statement, const DataItem &dataItem, const std::string &origDev, 239 DataOperStatus JudgeSyncSaveType(DataItem &dataItem, const DataItem &itemGet, 242 static std::string GetOriginDevName(const DataItem &dataItem, const std::string &origDevGet); 246 int GetSyncDataItemExt(const DataItem &dataItem, DataItem &itemGet, const DataOperStatus &dataStatus) const; 273 int SaveSyncDataToDatabase(const DataItem &dataItem, const Key &hashKey, const std::string &origDev, 288 const DataItem &dataItem, cons [all...] |
H A D | sqlite_single_ver_storage_executor.cpp | 475 int GetDataItemForSync(sqlite3_stmt *statement, DataItem &dataItem) in GetDataItemForSync() argument 477 dataItem.timestamp = static_cast<uint64_t>(sqlite3_column_int64(statement, SYNC_RES_TIME_INDEX)); in GetDataItemForSync() 478 dataItem.writeTimestamp = static_cast<uint64_t>(sqlite3_column_int64(statement, SYNC_RES_W_TIME_INDEX)); in GetDataItemForSync() 479 dataItem.flag = static_cast<uint64_t>(sqlite3_column_int64(statement, SYNC_RES_FLAG_INDEX)); in GetDataItemForSync() 480 dataItem.flag &= (~DataItem::LOCAL_FLAG); in GetDataItemForSync() 486 dataItem.origDev = std::string(devVect.begin(), devVect.end()); in GetDataItemForSync() 489 if ((dataItem.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG) { in GetDataItemForSync() 492 errCode = SQLiteUtils::GetColumnBlobValue(statement, keyIndex, dataItem.key); in GetDataItemForSync() 496 return SQLiteUtils::GetColumnBlobValue(statement, SYNC_RES_VAL_INDEX, dataItem.value); in GetDataItemForSync() 506 DataItem dataItem; in GetSyncDataItems() local 1192 GetOriginDevName(const DataItem &dataItem, const std::string &origDevGet) GetOriginDevName() argument 1201 SaveSyncDataToDatabase(const DataItem &dataItem, const Key &hashKey, const std::string &origDev, const std::string &deviceName, bool isUpdate) SaveSyncDataToDatabase() argument 1229 JudgeSyncSaveType(DataItem &dataItem, const DataItem &itemGet, const std::string &devName, bool isHashKeyExisted, bool isPermitForceWrite) JudgeSyncSaveType() argument 1258 GetSyncDataItemExt(const DataItem &dataItem, DataItem &itemGet, const DataOperStatus &dataStatus) const GetSyncDataItemExt() argument 1297 PrepareForNotifyConflictAndObserver(DataItem &dataItem, const DeviceInfo &deviceInfo, NotifyConflictAndObserverData ¬ify, bool isPermitForceWrite) PrepareForNotifyConflictAndObserver() argument 1353 SaveSyncDataItem(DataItem &dataItem, const DeviceInfo &deviceInfo, Timestamp &maxStamp, SingleVerNaturalStoreCommitNotifyData *committedData, bool isPermitForceWrite) SaveSyncDataItem() argument 1470 BindSavedSyncData(sqlite3_stmt *statement, const DataItem &dataItem, const Key &hashKey, const SyncDataDevices &devices, bool isUpdate) BindSavedSyncData() argument 1753 BindDevForSavedSyncData(sqlite3_stmt *statement, const DataItem &dataItem, const std::string &origDev, const std::string &deviceName) BindDevForSavedSyncData() argument 1918 GetOneRawDataItem(sqlite3_stmt *statement, DataItem &dataItem, uint64_t &verInCurCacheDb, bool isCacheDb) const GetOneRawDataItem() argument 1967 DataItem dataItem; GetAllDataItems() local 2246 BindSyncDataTime(sqlite3_stmt *statement, const DataItem &dataItem, bool isUpdate) BindSyncDataTime() argument [all...] |
H A D | sqlite_cloud_kv_executor_utils.h | 99 static int BindOnlyUpdateLogStmt(sqlite3_stmt *logStmt, const std::string &user, const DataItem &dataItem); 105 const DataItem &dataItem); 108 const DataItem &dataItem); 111 const DataItem &dataItem); 113 static int BindUpdateLogStmt(sqlite3_stmt *logStmt, const std::string &user, const DataItem &dataItem); 116 DataItem &dataItem); 118 static int BindDataStmt(sqlite3_stmt *dataStmt, const DataItem &dataItem, bool isInsert); 120 static int BindSyncDataStmt(sqlite3_stmt *dataStmt, const DataItem &dataItem, bool isInsert, int &index); 122 static int BindCloudDataStmt(sqlite3_stmt *dataStmt, const DataItem &dataItem, int &index); 160 const DataItem &dataItem, cons [all...] |
H A D | sqlite_single_ver_natural_store_connection.cpp | 961 DataItem dataItem; in SaveEntry() local 962 dataItem.key = entry.key; in SaveEntry() 963 dataItem.value = entry.value; in SaveEntry() 964 dataItem.flag = DataItem::LOCAL_FLAG; in SaveEntry() 966 dataItem.flag |= DataItem::DELETE_FLAG; in SaveEntry() 968 int errCode = CheckAmendValueContentForLocalProcedure(dataItem.value, dataItem.value); in SaveEntry() 974 RecordTimeIntoDataItem(timestamp, dataItem, *naturalStore); in SaveEntry() 977 return SaveEntryInCacheMode(dataItem, recordVersion); in SaveEntry() 979 return SaveEntryNormally(dataItem); in SaveEntry() 990 LocalDataItem dataItem; SaveLocalEntry() local 1035 SaveEntryNormally(DataItem &dataItem) SaveEntryNormally() argument 1056 SaveEntryInCacheMode(DataItem &dataItem, uint64_t recordVersion) SaveEntryInCacheMode() argument 1972 RecordTimeIntoDataItem(Timestamp existCreateTime, DataItem &dataItem, SQLiteSingleVerNaturalStore &naturalStore) RecordTimeIntoDataItem() argument [all...] |
H A D | sqlite_single_ver_natural_store_connection.h | 200 int SaveLocalItem(const LocalDataItem &dataItem) const; 201 int SaveLocalItemInCacheMode(const LocalDataItem &dataItem) const; 202 int SaveEntryNormally(DataItem &dataItem); 203 int SaveEntryInCacheMode(DataItem &dataItem, uint64_t recordVersion); 222 void RecordTimeIntoDataItem(Timestamp existCreateTime, DataItem &dataItem,
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
H A D | data_transformer.cpp | 31 DataItem dataItem; in TransformTableData() local 32 int errCode = SerializeDataItem(data, fieldInfoList, dataItem); in TransformTableData() 36 dataItems.push_back(std::move(dataItem)); in TransformTableData() 47 for (const DataItem &dataItem : dataItems) { in TransformDataItem() 49 int errCode = DeSerializeDataItem(dataItem, dataWithLog, remoteFieldInfo); in TransformDataItem() 59 const std::vector<FieldInfo> &fieldInfo, DataItem &dataItem) in SerializeDataItem() 61 int errCode = SerializeValue(dataItem.value, data.rowData, fieldInfo); in SerializeDataItem() 66 dataItem.timestamp = logInfo.timestamp; in SerializeDataItem() 67 dataItem.dev = logInfo.device; in SerializeDataItem() 68 dataItem in SerializeDataItem() 58 SerializeDataItem(const RowDataWithLog &data, const std::vector<FieldInfo> &fieldInfo, DataItem &dataItem) SerializeDataItem() argument 75 DeSerializeDataItem(const DataItem &dataItem, OptRowDataWithLog &data, const std::vector<FieldInfo> &remoteFieldInfo) DeSerializeDataItem() argument [all...] |
H A D | single_ver_natural_store_commit_notify_data.cpp | 113 DBCommon::CalcValueHash(itemInfo.dataItem.key, hashKey); in InsertConflictedItem() 123 auto iter = orgDataItem_.find(itemInfo.dataItem.key); in InsertConflictedItem() 126 orgDataItem_[itemInfo.dataItem.key] = itemInfo; in InsertConflictedItem() 222 if (orgItemInfo.dataItem.value == newItemInfo.dataItem.value && in PutIntoConflictData() 223 orgItemInfo.dataItem.origDev == newItemInfo.dataItem.origDev && in PutIntoConflictData() 224 orgItemInfo.dataItem.flag == newItemInfo.dataItem.flag && in PutIntoConflictData() 236 conflictData.type = ((newItemInfo.dataItem in PutIntoConflictData() [all...] |
H A D | data_transformer.h | 96 DataItem &dataItem); 97 static int DeSerializeDataItem(const DataItem &dataItem, OptRowDataWithLog &data,
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/ |
H A D | data_share_types_util.cpp | 50 bool Unmarshalling(PublishedDataItem &dataItem, MessageParcel &parcel) in Unmarshalling() argument 52 return ITypesUtil::Unmarshal(parcel, dataItem.key_, dataItem.subscriberId_, dataItem.value_); in Unmarshalling() 56 bool Marshalling(const PublishedDataItem &dataItem, MessageParcel &parcel) in Marshalling() argument 58 return ITypesUtil::Marshal(parcel, dataItem.key_, dataItem.subscriberId_, dataItem.value_); in Marshalling()
|
H A D | data_share_types_util.h | 42 bool Unmarshalling(PublishedDataItem &dataItem, MessageParcel &parcel); 45 bool Marshalling(const PublishedDataItem &dataItem, MessageParcel &parcel);
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | distributeddb_storage_register_observer_test.cpp | 201 DataItem dataItem; in TestForOperation() local 202 dataItem.key = entry.key; in TestForOperation() 203 dataItem.value = entry.value; in TestForOperation() 204 dataItem.timestamp = time + 1; in TestForOperation() 205 dataItem.writeTimestamp = dataItem.timestamp; in TestForOperation() 206 dataItem.flag = 0; in TestForOperation() 208 insertDataItems.push_back(dataItem); in TestForOperation() 215 dataItem.timestamp++; in TestForOperation() 216 dataItem in TestForOperation() 683 DataItem dataItem = {g_entry1.key, g_entry1.value, ++time, 1}; PreSyncDataForRegisterObserver014() local [all...] |
H A D | distributeddb_storage_sqlite_single_ver_natural_executor_test.cpp | 946 DataItem dataItem; in HWTEST_F() local 948 items.push_back(dataItem); in HWTEST_F() 980 items.push_back(dataItem); in HWTEST_F() 1019 DataItem dataItem; in HWTEST_F() local 1021 items.push_back(dataItem); in HWTEST_F() 1050 DataItem dataItem; in HWTEST_F() local 1052 items.push_back(dataItem); in HWTEST_F() 1118 DataItem dataItem; in HWTEST_F() local 1119 dataItem.flag = DataItem::REMOTE_DEVICE_DATA_MISS_QUERY; in HWTEST_F() 1122 EXPECT_EQ(executor->SaveSyncDataItemInCacheMode(dataItem, inf in HWTEST_F() [all...] |
H A D | distributeddb_storage_rd_single_ver_natural_executor_test.cpp | 514 DataItem dataItem; in HWTEST_F() local 516 items.push_back(dataItem); in HWTEST_F() 545 DataItem dataItem; in HWTEST_F() local 547 items.push_back(dataItem); in HWTEST_F()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
H A D | virtual_single_ver_sync_db_Interface.cpp | 258 int VirtualSingleVerSyncDBInterface::GetSyncData(const Key &key, VirtualDataItem &dataItem) in GetSyncData() argument 266 dataItem.key = iter->key; in GetSyncData() 267 dataItem.value = iter->value; in GetSyncData() 268 dataItem.timestamp = iter->timestamp; in GetSyncData() 269 dataItem.writeTimestamp = iter->writeTimestamp; in GetSyncData() 270 dataItem.flag = iter->flag; in GetSyncData() 271 dataItem.isLocal = iter->isLocal; in GetSyncData() 389 VirtualDataItem dataItem; in PutSyncData() local 390 dataItem.key = iter->key; in PutSyncData() 391 dataItem in PutSyncData() [all...] |
/foundation/distributeddatamgr/data_share/frameworks/native/common/src/ |
H A D | datashare_itypes_utils.cpp | 87 bool Unmarshalling(PublishedDataItem &dataItem, MessageParcel &parcel) in Unmarshalling() argument 89 return ITypesUtil::Unmarshal(parcel, dataItem.key_, dataItem.subscriberId_, dataItem.value_); in Unmarshalling() 93 bool Marshalling(const PublishedDataItem &dataItem, MessageParcel &parcel) in Marshalling() argument 95 return ITypesUtil::Marshal(parcel, dataItem.key_, dataItem.subscriberId_, dataItem.value_); in Marshalling()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
H A D | sqlite_single_ver_relational_storage_executor.cpp | 769 int SQLiteSingleVerRelationalStorageExecutor::GetLogInfoPre(sqlite3_stmt *queryStmt, const DataItem &dataItem, in GetLogInfoPre() argument 775 int errCode = SQLiteUtils::BindBlobToStatement(queryStmt, 1, dataItem.hashKey); // 1 means hashkey index. in GetLogInfoPre() 780 errCode = SQLiteUtils::BindTextToStatement(queryStmt, 2, dataItem.dev); // 2 means device index. in GetLogInfoPre() 796 const DataItem &dataItem, int64_t rowid) in SaveSyncLog() 799 int errCode = GetLogInfoPre(queryStmt, dataItem, logInfoGet); in SaveSyncLog() 801 logInfoBind.hashKey = dataItem.hashKey; in SaveSyncLog() 802 logInfoBind.device = dataItem.dev; in SaveSyncLog() 803 logInfoBind.timestamp = dataItem.timestamp; in SaveSyncLog() 804 logInfoBind.flag = dataItem.flag; in SaveSyncLog() 807 logInfoBind.wTimestamp = dataItem in SaveSyncLog() 795 SaveSyncLog(sqlite3_stmt *statement, sqlite3_stmt *queryStmt, const DataItem &dataItem, int64_t rowid) SaveSyncLog() argument 831 DeleteSyncDataItem(const DataItem &dataItem, RelationalSyncDataInserter &inserter, sqlite3_stmt *&stmt) DeleteSyncDataItem() argument 862 SaveSyncDataItem(const DataItem &dataItem, SaveSyncDataStmt &saveStmt, RelationalSyncDataInserter &inserter, int64_t &rowid) SaveSyncDataItem() argument 893 DeleteSyncLog(const DataItem &dataItem, RelationalSyncDataInserter &inserter, sqlite3_stmt *&stmt) DeleteSyncLog() argument 934 GetSyncDataPre(const DataItem &dataItem, sqlite3_stmt *queryStmt, DataItem &itemGet) GetSyncDataPre() argument 944 CheckDataConflictDefeated(const DataItem &dataItem, sqlite3_stmt *queryStmt, bool &isDefeated) CheckDataConflictDefeated() argument 1046 GetDataItemForSync(sqlite3_stmt *stmt, DataItem &dataItem, bool isGettingDeletedData) const GetDataItemForSync() argument [all...] |
H A D | sqlite_single_ver_relational_storage_executor.h | 252 int GetDataItemForSync(sqlite3_stmt *statement, DataItem &dataItem, bool isGettingDeletedData) const; 254 int GetSyncDataPre(const DataItem &dataItem, sqlite3_stmt *queryStmt, DataItem &itemGet); 260 int SaveSyncDataItem(const DataItem &dataItem, SaveSyncDataStmt &saveStmt, RelationalSyncDataInserter &inserter, 263 int DeleteSyncDataItem(const DataItem &dataItem, RelationalSyncDataInserter &inserter, sqlite3_stmt *&rmDataStmt); 265 int GetLogInfoPre(sqlite3_stmt *queryStmt, const DataItem &dataItem, LogInfo &logInfoGet); 267 int SaveSyncLog(sqlite3_stmt *statement, sqlite3_stmt *queryStmt, const DataItem &dataItem, int64_t rowid);
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
H A D | cloud_storage_utils.cpp | 1359 auto &[errCode, dataItem] = res; in GetDataItemFromCloudData() 1360 GetBytesFromCloudData(CloudDbConstant::CLOUD_KV_FIELD_KEY, data, dataItem.key); in GetDataItemFromCloudData() 1361 GetBytesFromCloudData(CloudDbConstant::CLOUD_KV_FIELD_VALUE, data, dataItem.value); in GetDataItemFromCloudData() 1362 GetStringFromCloudData(CloudDbConstant::GID_FIELD, data, dataItem.gid); in GetDataItemFromCloudData() 1363 GetStringFromCloudData(CloudDbConstant::VERSION_FIELD, data, dataItem.version); in GetDataItemFromCloudData() 1364 GetStringFromCloudData(CloudDbConstant::CLOUD_KV_FIELD_DEVICE, data, dataItem.dev); in GetDataItemFromCloudData() 1365 GetStringFromCloudData(CloudDbConstant::CLOUD_KV_FIELD_ORI_DEVICE, data, dataItem.origDev); in GetDataItemFromCloudData() 1366 dataItem.flag = static_cast<uint64_t>(LogInfoFlag::FLAG_CLOUD_WRITE); in GetDataItemFromCloudData() 1367 GetUInt64FromCloudData(CloudDbConstant::CLOUD_KV_FIELD_DEVICE_CREATE_TIME, data, dataItem.writeTimestamp); in GetDataItemFromCloudData() 1368 GetUInt64FromCloudData(CloudDbConstant::MODIFY_FIELD, data, dataItem in GetDataItemFromCloudData() [all...] |
/foundation/distributeddatamgr/preferences/frameworks/native/platform/src/ |
H A D | preferences_db_adapter.cpp | 422 std::pair<std::vector<uint8_t>, std::vector<uint8_t>> dataItem; in GetAllInner() local 430 dataItem.first.resize(keySize); in GetAllInner() 431 dataItem.second.resize(valueSize); in GetAllInner() 432 ret = PreferenceDbAdapter::GetApiInstance().GetItemApi(resultSet, dataItem.first.data(), in GetAllInner() 433 dataItem.second.data()); in GetAllInner() 438 data.emplace_back(std::move(dataItem)); in GetAllInner()
|
/foundation/distributeddatamgr/data_share/frameworks/native/common/include/ |
H A D | datashare_itypes_utils.h | 69 bool Unmarshalling(PublishedDataItem &dataItem, MessageParcel &parcel); 72 bool Unmarshalling(PublishedDataItem &dataItem, MessageParcel &parcel);
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
H A D | relational_sync_data_inserter.h | 64 int BindInsertStatement(sqlite3_stmt *stmt, const DataItem &dataItem);
|
/foundation/bundlemanager/bundle_framework/interfaces/inner_api/appexecfwk_base/src/ |
H A D | shortcut_info.cpp | 127 for (const auto &dataItem : intents[i].parameters) { in Marshalling() 128 WRITE_PARCEL_AND_RETURN_FALSE_IF_FAIL(String16, parcel, Str8ToStr16(dataItem.first)); in Marshalling() 129 WRITE_PARCEL_AND_RETURN_FALSE_IF_FAIL(String16, parcel, Str8ToStr16(dataItem.second)); in Marshalling()
|
/foundation/multimedia/ringtone_library/services/ringtone_data_extension/src/ |
H A D | ringtone_language_manager.cpp | 284 auto dataItem = fieldIndex.find(dataIndexField); in SetValuesFromResultSet() local 285 if (dataItem == fieldIndex.end()) { in SetValuesFromResultSet() 289 if (resultSet->GetString(dataItem->second, data) != E_OK) { in SetValuesFromResultSet()
|