| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_data_inserter.cpp | 55 RelationalSyncDataInserter inserter; in CreateInserter() local
56 inserter.SetHashDevId(DBCommon::TransferStringToHex(DBCommon::TransferHashString(deviceName))); in CreateInserter()
57 inserter.SetRemoteFields(remoteFields); in CreateInserter()
58 inserter.SetQuery(query); in CreateInserter()
60 inserter.SetLocalTable(localTable); in CreateInserter()
61 inserter.SetTableMode(localSchema.GetTableMode()); in CreateInserter()
63 inserter.SetInsertTableName(localTable.GetTableName()); in CreateInserter()
65 …inserter.SetInsertTableName(DBCommon::GetDistributedTableName(deviceName, localTable.GetTableName(… in CreateInserter()
67 return inserter; in CreateInserter()
|
| H A D | relational_sync_able_storage.cpp | 550 …auto inserter = RelationalSyncDataInserter::CreateInserter(deviceName, query, storageEngine_->GetS… in SaveSyncDataItems() local
552 inserter.SetEntries(dataItems); in SaveSyncDataItems()
561 errCode = handle->SaveSyncItems(inserter); in SaveSyncDataItems()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 850 RelationalSyncDataInserter &inserter, sqlite3_stmt *&stmt) in DeleteSyncDataItem() argument
881 RelationalSyncDataInserter &inserter, int64_t &rowid) in SaveSyncDataItem() argument
912 RelationalSyncDataInserter &inserter, sqlite3_stmt *&stmt) in DeleteSyncLog() argument
915 int errCode = inserter.GetDeleteLogStmt(dbHandle_, stmt); in DeleteSyncLog()
945 int errCode = DeleteSyncDataItem(item, inserter, rmDataStmt); in ProcessMissQueryData()
949 return DeleteSyncLog(item, inserter, rmLogStmt); in ProcessMissQueryData()
999 errCode = SaveSyncDataItem(item, saveStmt, inserter, rowid); in SaveSyncDataItem()
1009 int errCode = inserter.PrepareStatement(dbHandle_, saveStmt); in SaveSyncDataItems()
1015 errCode = inserter.Iterate([this, &saveStmt, &inserter] (DataItem &item) -> int { in SaveSyncDataItems()
1019 int errCode = SaveSyncDataItem(inserter, saveStmt, item); in SaveSyncDataItems()
[all …]
|
| H A D | sqlite_single_ver_relational_storage_executor.h | 83 int SaveSyncItems(RelationalSyncDataInserter &inserter, bool useTrans = true);
109 int SaveSyncDataItems(RelationalSyncDataInserter &inserter);
258 …int SaveSyncDataItem(RelationalSyncDataInserter &inserter, SaveSyncDataStmt &saveStmt, DataItem &i…
260 …ataItem(const DataItem &dataItem, SaveSyncDataStmt &saveStmt, RelationalSyncDataInserter &inserter,
263 …int DeleteSyncDataItem(const DataItem &dataItem, RelationalSyncDataInserter &inserter, sqlite3_stm…
271 …int DeleteSyncLog(const DataItem &item, RelationalSyncDataInserter &inserter, sqlite3_stmt *&rmLog…
272 …int ProcessMissQueryData(const DataItem &item, RelationalSyncDataInserter &inserter, sqlite3_stmt …
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/drawing/engine_adapter/skia_adapter/ |
| H A D | skia_hm_symbol_config_ohos.cpp | 113 std::inserter(out.curveArgs, out.curveArgs.begin())); in ConvertPiecewiseParameter()
115 std::inserter(out.properties, out.properties.begin())); in ConvertPiecewiseParameter()
|
| /ohos5.0/drivers/hdf_core/adapter/uhdf2/hdi/test/smq_test/ |
| H A D | smq_test.cpp | 239 std::inserter(unclosedFds, unclosedFds.begin()));
299 std::inserter(hostUnclosedFds, hostUnclosedFds.begin()));
308 std::inserter(servHostUnclosedFds, servHostUnclosedFds.begin()));
|
| /ohos5.0/foundation/filemanagement/app_file_service/tests/unittests/backup_sa/module_ipc/ |
| H A D | sched_scheduler_test.cpp | 78 …transform(bundleNames.begin(), bundleNames.end(), inserter(backupExtNameMap, backupExtNameMap.end(… in Init()
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/Lume_3D/src/ecs/systems/ |
| H A D | node_system.cpp | 851 auto inserter = std::back_inserter(entitiesWithNode); in Refresh() local
852 …inserter = std::set_difference(nodeEntities_.cbegin(), nodeEntities_.cend(), first, last, inserter, in Refresh()
858 …inserter = std::set_difference(first, last, nodeEntities_.cbegin(), nodeEntities_.cend(), inserter, in Refresh()
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/v4l2/src/stream_operator/ |
| H A D | stream_operator_vdi_impl.cpp | 103 std::inserter(cfiSet, cfiSet.begin())); in GetStreamSupportType()
108 std::inserter(expectCurrentSet, expectCurrentSet.begin())); in GetStreamSupportType()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_task_context.cpp | 465 inserter(algoIntersection, algoIntersection.begin())); in ChooseCompressAlgo()
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/avrcp_tg/ |
| H A D | avrcp_tg_connection.cpp | 169 std::transform(infos_.begin(), infos_.end(), std::inserter(addrs, addrs.end()), in GetDeviceAddresses()
|
| /ohos5.0/foundation/barrierfree/accessibility/services/aams/src/ |
| H A D | accessibility_settings_config.cpp | 265 std::copy_if(name.begin(), name.end(), std::inserter(targets, targets.end()), in SetShortkeyMultiTarget()
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/avrcp_ct/ |
| H A D | avrcp_ct_connection.cpp | 195 std::transform(infos_.begin(), infos_.end(), std::inserter(addrs,addrs.end()), in GetDeviceAddresses()
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/text/ |
| H A D | span_node.cpp | 1115 propertyInfo_.end(), inserter(inheritPropertyInfo, inheritPropertyInfo.begin())); in CalculateInheritPropertyInfo()
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/core/components_v2/common/ |
| H A D | element_proxy.cpp | 1642 std::inserter(idsToRemove, idsToRemove.begin())); in ReleaseRedundantComposeIds()
|
| /ohos5.0/foundation/communication/netstack/frameworks/native/tls_socket/src/ |
| H A D | tls_socket_server.cpp | 92 …set_intersection(vecA.begin(), vecA.end(), vecB.begin(), vecB.end(), inserter(result, result.begin… in SeekIntersection()
|
| H A D | tls_socket.cpp | 177 …set_intersection(vecA.begin(), vecA.end(), vecB.begin(), vecB.end(), inserter(result, result.begin… in SeekIntersection()
|
| /ohos5.0/foundation/resourceschedule/device_standby/services/core/src/ |
| H A D | standby_service_impl.cpp | 879 allowSet.end(), std::inserter(restrictSet, restrictSet.begin())); in GetEligiableRestrictSet()
|