/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
H A D | virtual_cloud_db.cpp | 35 std::vector<VBucket> &extend) in BatchInsert() 43 if (record.size() != extend.size()) { in BatchInsert() 48 DBStatus status = InnerBatchInsert(tableName, std::move(record), extend); in BatchInsert() 53 extend.erase(extend.end()); in BatchInsert() 56 extend.push_back(vBucket); in BatchInsert() 70 std::vector<VBucket> &extend) in InnerBatchInsert() 77 if (extend[i].find(g_gidField) != extend[i].end()) { in InnerBatchInsert() 82 DBStatus ret = forkUploadConflictFunc_(tableName, extend[ in InnerBatchInsert() 34 BatchInsert(const std::string &tableName, std::vector<VBucket> &&record, std::vector<VBucket> &extend) BatchInsert() argument 69 InnerBatchInsert(const std::string &tableName, std::vector<VBucket> &&record, std::vector<VBucket> &extend) InnerBatchInsert() argument 109 BatchInsertWithGid(const std::string &tableName, std::vector<VBucket> &&record, std::vector<VBucket> &extend) BatchInsertWithGid() argument 155 BatchUpdate(const std::string &tableName, std::vector<VBucket> &&record, std::vector<VBucket> &extend) BatchUpdate() argument 167 BatchDelete(const std::string &tableName, std::vector<VBucket> &extend) BatchDelete() argument 248 DeleteByGid(const std::string &tableName, VBucket &extend) DeleteByGid() argument 264 Query(const std::string &tableName, VBucket &extend, std::vector<VBucket> &data) Query() argument 307 GetCloudData(const std::string &cursor, bool isIncreCursor, std::vector<CloudData> allData, std::vector<VBucket> &data, VBucket &extend) GetCloudData() argument 384 IsCloudGidMatching(const std::vector<QueryNode> &queryNodes, VBucket &extend) IsCloudGidMatching() argument 396 IsCloudGidMatchingInner(const QueryNode &queryNode, VBucket &extend) IsCloudGidMatchingInner() argument 406 InnerUpdate(const std::string &tableName, std::vector<VBucket> &&record, std::vector<VBucket> &extend, bool isDelete) InnerUpdate() argument 437 InnerUpdateWithoutLock(const std::string &tableName, std::vector<VBucket> &&record, std::vector<VBucket> &extend, bool isDelete) InnerUpdateWithoutLock() argument 552 SetIncrementData(const std::string &tableName, const VBucket &record, const VBucket &extend) SetIncrementData() argument 640 AddAssetIdForExtend(VBucket &record, VBucket &extend) AddAssetIdForExtend() argument [all...] |
H A D | virtual_cloud_db.h | 27 VBucket extend; member 32 std::vector<VBucket> &extend) override; 35 std::vector<VBucket> &extend); 38 std::vector<VBucket> &extend) override; 40 DBStatus BatchDelete(const std::string &tableName, std::vector<VBucket> &extend) override; 42 DBStatus Query(const std::string &tableName, VBucket &extend, std::vector<VBucket> &data) override; 44 DBStatus DeleteByGid(const std::string &tableName, VBucket &extend); 68 void SetIncrementData(const std::string &tableName, const VBucket &record, const VBucket &extend); 102 std::vector<VBucket> &extend); 105 std::vector<VBucket> &extend, boo [all...] |
H A D | distributeddb_cloud_syncer_download_assets_test.cpp | 141 int64_t begin, int64_t count, int64_t gidStart, std::vector<VBucket> &record, std::vector<VBucket> &extend) in GenerateDataRecords() 164 extend.push_back(log); in GenerateDataRecords() 172 std::vector<VBucket> extend; in InsertLocalData() local 173 GenerateDataRecords(begin, count, 0, record, extend); in InsertLocalData() 247 std::vector<VBucket> extend; in UpdateCloudDBData() local 248 GenerateDataRecords(begin, count, gidStart, record, extend); in UpdateCloudDBData() 249 for (auto &entry: extend) { in UpdateCloudDBData() 252 ASSERT_EQ(g_virtualCloudDb->BatchUpdate(tableName, std::move(record), extend), DBStatus::OK); in UpdateCloudDBData() 285 std::vector<VBucket> extend; in InsertCloudDBData() local 286 GenerateDataRecords(begin, count, gidStart, record, extend); in InsertCloudDBData() 140 GenerateDataRecords( int64_t begin, int64_t count, int64_t gidStart, std::vector<VBucket> &record, std::vector<VBucket> &extend) GenerateDataRecords() argument [all...] |
/foundation/multimedia/image_framework/frameworks/innerkitsimpl/common/src/ |
H A D | memory_manager.cpp | 120 extend.size = sizeof(int);
in Create() 121 extend.data = fdPtr.release();
in Create() 133 ReleaseSharedMemory(static_cast<int*>(extend.data), static_cast<uint8_t*>(data.data), data.size);
in Release() 136 if (extend.data != nullptr) {
in Release() 137 free(extend.data);
in Release() 138 extend.data = nullptr;
in Release() 139 extend.size = SIZE_ZERO;
in Release() 208 extend.size = data.size;
in Create() 209 extend.data = nativeBuffer;
in Create() 222 if (extend in Release() 241 CreateMemory(AllocatorType type, MemoryData &data, MemoryData &extend) CreateMemory() argument [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
H A D | rdb_cloud.cpp | 35 const std::string &tableName, std::vector<DBVBucket> &&record, std::vector<DBVBucket> &extend) in BatchInsert() 37 extend.resize(record.size()); in BatchInsert() 38 VBuckets extends = ValueProxy::Convert(std::move(extend)); in BatchInsert() 46 extend = ValueProxy::Convert(std::move(extends)); in BatchInsert() 51 const std::string &tableName, std::vector<DBVBucket> &&record, std::vector<DBVBucket> &extend) in BatchUpdate() 53 extend.resize(record.size()); in BatchUpdate() 54 VBuckets extends = ValueProxy::Convert(std::move(extend)); in BatchUpdate() 62 extend = ValueProxy::Convert(std::move(extends)); in BatchUpdate() 66 DBStatus RdbCloud::BatchDelete(const std::string &tableName, std::vector<DBVBucket> &extend) in BatchDelete() argument 68 VBuckets extends = ValueProxy::Convert(std::move(extend)); in BatchDelete() 34 BatchInsert( const std::string &tableName, std::vector<DBVBucket> &&record, std::vector<DBVBucket> &extend) BatchInsert() argument 50 BatchUpdate( const std::string &tableName, std::vector<DBVBucket> &&record, std::vector<DBVBucket> &extend) BatchUpdate() argument 75 Query(const std::string &tableName, DBVBucket &extend, std::vector<DBVBucket> &data) Query() argument 114 PreSharing(const std::string& tableName, VBuckets& extend) PreSharing() argument 208 ConvertQuery(RdbCloud::DBVBucket& extend) ConvertQuery() argument 269 PostEvent(VBuckets& records, std::set<std::string>& skipAssets, VBuckets& extend, DistributedData::AssetEvent eventId) PostEvent() argument 281 PostEvent(DistributedData::Value& value, DataBucket& extend, std::set<std::string>& skipAssets, DistributedData::AssetEvent eventId) PostEvent() argument 301 PostEventAsset(DistributedData::Asset& asset, DataBucket& extend, std::set<std::string>& skipAssets, DistributedData::AssetEvent eventId) PostEventAsset() argument [all...] |
H A D | rdb_cloud.h | 44 std::vector<DBVBucket> &extend) override; 46 std::vector<DBVBucket> &extend) override; 47 DBStatus BatchDelete(const std::string &tableName, std::vector<DBVBucket> &extend) override; 48 DBStatus Query(const std::string &tableName, DBVBucket &extend, std::vector<DBVBucket> &data) override; 49 DistributedData::GeneralError PreSharing(const std::string &tableName, DistributedData::VBuckets &extend); 65 static std::pair<QueryNodes, DistributedData::GeneralError> ConvertQuery(DBVBucket& extend); 75 DistributedData::VBuckets& extend, DistributedData::AssetEvent eventId); 76 void PostEvent(DistributedData::Value& value, DataBucket& extend, std::set<std::string>& skipAssets, 78 void PostEventAsset(DistributedData::Asset& asset, DataBucket& extend, std::set<std::string>& skipAssets,
|
/third_party/gn/build/ |
H A D | gen.py | 323 ninja_lines.extend([ 348 ninja_lines.extend([ 406 cflags.extend(['-O0', '-g']) 412 cflags.extend(['-D_LIBCPP_DEBUG=1', '-D_GLIBCXX_DEBUG=1']) 422 cflags.extend(['-fdata-sections', '-ffunction-sections']) 423 ldflags.extend(['-fdata-sections', '-ffunction-sections']) 447 cflags.extend(['-flto', '-fwhole-program-vtables']) 448 ldflags.extend(['-flto', '-fwhole-program-vtables']) 461 cflags.extend([ 483 cflags.extend([' [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
H A D | cloud_sync_utils.cpp | 219 size_t insExtendLen = uploadData.insData.extend.size(); in CheckCloudSyncDataValid() 221 size_t updExtendLen = uploadData.updData.extend.size(); in CheckCloudSyncDataValid() 223 size_t delExtendLen = uploadData.delData.extend.size(); in CheckCloudSyncDataValid() 229 (uploadData.lockData.extend.size() > 0)); in CheckCloudSyncDataValid() 247 std::vector<VBucket>().swap(uploadData.insData.extend); in ClearCloudSyncData() 250 std::vector<VBucket>().swap(uploadData.updData.extend); in ClearCloudSyncData() 252 std::vector<VBucket>().swap(uploadData.delData.extend); in ClearCloudSyncData() 255 int CloudSyncUtils::GetWaterMarkAndUpdateTime(std::vector<VBucket> &extend, Timestamp &waterMark) in GetWaterMarkAndUpdateTime() argument 257 for (auto &extendData: extend) { in GetWaterMarkAndUpdateTime() 287 return uploadData.insData.extend in CheckCloudSyncDataEmpty() 433 IsSkipAssetsMissingRecord(const std::vector<VBucket> &extend) IsSkipAssetsMissingRecord() argument 493 FillAssetIdToAssetData(const Type &extend, Type &assetData) FillAssetIdToAssetData() argument 512 FillAssetIdToAssetsData(const Assets &extend, Assets &assets) FillAssetIdToAssetsData() argument [all...] |
H A D | cloud_db_proxy.cpp | 96 std::vector<VBucket> &extend, Info &uploadInfo) in BatchInsert() 104 context->MoveInRecordAndExtend(record, extend); in BatchInsert() 108 context->MoveOutRecordAndExtend(record, extend); in BatchInsert() 113 std::vector<VBucket> &extend, Info &uploadInfo) in BatchUpdate() 122 context->MoveInRecordAndExtend(record, extend); in BatchUpdate() 125 context->MoveOutRecordAndExtend(record, extend); in BatchUpdate() 129 int CloudDBProxy::BatchDelete(const std::string &tableName, std::vector<VBucket> &record, std::vector<VBucket> &extend, in BatchDelete() argument 138 context->MoveInRecordAndExtend(record, extend); in BatchDelete() 142 context->MoveOutRecordAndExtend(record, extend); in BatchDelete() 146 int CloudDBProxy::Query(const std::string &tableName, VBucket &extend, st argument 95 BatchInsert(const std::string &tableName, std::vector<VBucket> &record, std::vector<VBucket> &extend, Info &uploadInfo) BatchInsert() argument 112 BatchUpdate(const std::string &tableName, std::vector<VBucket> &record, std::vector<VBucket> &extend, Info &uploadInfo) BatchUpdate() argument 336 std::vector<VBucket> extend; DMLActionTask() local 499 MoveInRecordAndExtend(std::vector<VBucket> &record, std::vector<VBucket> &extend) MoveInRecordAndExtend() argument 507 MoveInExtend(std::vector<VBucket> &extend) MoveInExtend() argument 513 MoveOutRecordAndExtend(std::vector<VBucket> &record, std::vector<VBucket> &extend) MoveOutRecordAndExtend() argument 521 MoveInQueryExtendAndData(VBucket &extend, std::vector<VBucket> &data) MoveInQueryExtendAndData() argument 528 MoveOutQueryExtendAndData(VBucket &extend, std::vector<VBucket> &data) MoveOutQueryExtendAndData() argument 600 IsRecordActionFail(const VBucket &extend, bool isInsert, DBStatus status) IsRecordActionFail() argument [all...] |
H A D | cloud_db_proxy.h | 43 std::vector<VBucket> &extend, Info &uploadInfo); 45 int BatchUpdate(const std::string &tableName, std::vector<VBucket> &record, std::vector<VBucket> &extend, 48 int BatchDelete(const std::string &tableName, std::vector<VBucket> &record, std::vector<VBucket> &extend, 51 int Query(const std::string &tableName, VBucket &extend, std::vector<VBucket> &data); 86 void MoveInRecordAndExtend(std::vector<VBucket> &record, std::vector<VBucket> &extend); 88 void MoveInExtend(std::vector<VBucket> &extend); 90 void MoveOutRecordAndExtend(std::vector<VBucket> &record, std::vector<VBucket> &extend); 92 void MoveInQueryExtendAndData(VBucket &extend, std::vector<VBucket> &data); 94 void MoveOutQueryExtendAndData(VBucket &extend, std::vector<VBucket> &data); 120 static bool IsRecordActionFail(const VBucket &extend, boo [all...] |
/third_party/protobuf/python/compatibility_tests/v2.5.0/tests/google/protobuf/internal/ |
H A D | test_util.py | 588 message.packed_int32.extend([601, 701]) 589 message.packed_int64.extend([602, 702]) 590 message.packed_uint32.extend([603, 703]) 591 message.packed_uint64.extend([604, 704]) 592 message.packed_sint32.extend([605, 705]) 593 message.packed_sint64.extend([606, 706]) 594 message.packed_fixed32.extend([607, 707]) 595 message.packed_fixed64.extend([608, 708]) 596 message.packed_sfixed32.extend([609, 709]) 597 message.packed_sfixed64.extend([61 [all...] |
/third_party/rust/crates/syn/codegen/src/ |
H A D | fold.rs | 58 code.extend(val); in visit() 59 code.extend(quote!(,)); in visit() 96 fold_variants.extend(quote! { in node() 108 bind_fold_fields.extend(quote! { in node() 114 fold_fields.extend( in node() 118 fold_fields.extend(quote!(,)); in node() 121 fold_variants.extend(quote! { in node() 131 fold_impl.extend(quote! { in node() 146 fold_fields.extend(quote! { in node() 153 fold_impl.extend(quot in node() [all...] |
H A D | visit.rs | 76 code.extend(val); in visit() 77 code.extend(quote!(;)); in visit() 106 visit_impl.extend(quote! { in node() 117 visit_variants.extend(quote! { in node() 127 bind_visit_fields.extend(quote! { in node() 133 visit_fields.extend( in node() 138 visit_fields.extend(quote!(;)); in node() 141 visit_variants.extend(quote! { in node() 149 visit_impl.extend(quote! { in node() 161 visit_impl.extend(quot in node() [all...] |
H A D | visit_mut.rs | 76 code.extend(val); in visit() 77 code.extend(quote!(;)); in visit() 106 visit_mut_impl.extend(quote! { in node() 117 visit_mut_variants.extend(quote! { in node() 127 bind_visit_mut_fields.extend(quote! { in node() 133 visit_mut_fields.extend( in node() 138 visit_mut_fields.extend(quote!(;)); in node() 141 visit_mut_variants.extend(quote! { in node() 149 visit_mut_impl.extend(quote! { in node() 161 visit_mut_impl.extend(quot in node() [all...] |
/third_party/python/Tools/scripts/ |
H A D | run_tests.py | 56 args.extend(test.support.args_from_interpreter_flags()) 58 args.extend(['-m', 'test', # Run the test suite 68 args.extend(['-j', '2']) 70 args.extend(['-j', '0']) # Use all CPU cores 72 args.extend(['-u', 'all,-largefile,-audio,-gui']) 79 args.extend(["--python", f"{hostrunner} {buildpython}"]) 81 args.extend(regrtest_args)
|
H A D | generate_sre_constants.py | 60 content.extend(dump(ns["OPCODES"], "SRE_OP")) 61 content.extend(dump(ns["ATCODES"], "SRE")) 62 content.extend(dump(ns["CHCODES"], "SRE")) 63 content.extend(dump2(ns, "SRE_FLAG_")) 64 content.extend(dump2(ns, "SRE_INFO_")) 70 content.extend(dump_gotos(ns["OPCODES"], "TARGET_SRE_OP"))
|
/third_party/protobuf/python/google/protobuf/internal/ |
H A D | test_util.py | 655 message.packed_int32.extend([601, 701]) 656 message.packed_int64.extend([602, 702]) 657 message.packed_uint32.extend([603, 703]) 658 message.packed_uint64.extend([604, 704]) 659 message.packed_sint32.extend([605, 705]) 660 message.packed_sint64.extend([606, 706]) 661 message.packed_fixed32.extend([607, 707]) 662 message.packed_fixed64.extend([608, 708]) 663 message.packed_sfixed32.extend([609, 709]) 664 message.packed_sfixed64.extend([61 [all...] |
/third_party/rust/crates/cxx/macro/src/ |
H A D | derive.rs | 14 Trait::Copy => expanded.extend(struct_copy(strct, span)), in expand_struct() 15 Trait::Clone => expanded.extend(struct_clone(strct, span)), in expand_struct() 16 Trait::Debug => expanded.extend(struct_debug(strct, span)), in expand_struct() 17 Trait::Default => expanded.extend(struct_default(strct, span)), in expand_struct() 21 Trait::Ord => expanded.extend(struct_ord(strct, span)), in expand_struct() 23 Trait::PartialOrd => expanded.extend(struct_partial_ord(strct, span)), in expand_struct() 50 expanded.extend(enum_copy(enm, span)); in expand_enum() 54 expanded.extend(enum_clone(enm, span)); in expand_enum() 57 Trait::Debug => expanded.extend(enum_debug(enm, span)), in expand_enum() 65 Trait::Ord => expanded.extend(enum_or in expand_enum() [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/c_adapter/ |
H A D | cloud_extension.rs | 281 extend: *mut OhCloudExtHashMap, 283 if cdb.is_null() || sql.is_null() || extend.is_null() { 298 let extend = match OhCloudExtHashMap::get_inner_mut(extend, SafetyCheckId::HashMap) { 302 let extend = &mut (*match extend { 306 match cdb.execute(table, sql, extend) { 321 extend: *mut OhCloudExtVector, 323 if cdb.is_null() || table.is_null() || value.is_null() || extend.is_null() { 342 let extend [all...] |
/third_party/typescript/tests/baselines/reference/ |
H A D | intersectionThisTypes.js | 30 extend<T>(props: T): this & T; 38 const extended = label.extend({ id: 67 }).extend({ tag: "hello" }); 54 var extended = label.extend({ id: 67 }).extend({ tag: "hello" });
|
H A D | objectLiteralParameterResolution.js | 3 extend<T>(target: T, ...objs: any[]): T; 4 extend<T>(deep: boolean, target: T, ...objs: any[]): T; 7 var s = $.extend({ 20 var s = $.extend({
|
/third_party/skia/infra/bots/recipes/ |
H A D | test.py | 118 args.extend([k, v]) 122 args.extend(['--resourcePath', api.flavor.device_dirs.resource_dir]) 124 args.extend(['--skps', api.flavor.device_dirs.skp_dir]) 126 args.extend([ 135 args.extend(['--svgs', api.flavor.device_path_join( 138 args.extend([ 146 args.extend(['--uninterestingHashesFile', hashes_file]) 148 args.extend(['--writePath', api.flavor.device_dirs.dm_dir])
|
/third_party/skia/tools/skpbench/ |
H A D | skpbench.py | 141 ARGV.extend(['--duration', str(FLAGS.duration)]) 143 ARGV.extend(['--sampleMs', str(FLAGS.sample_ms)]) 145 ARGV.extend(['--gpuClock', 'true']) 147 ARGV.extend(['--fps', 'true']) 149 ARGV.extend(['--pr'] + re.split(r'[ ,]', FLAGS.pr)) 151 ARGV.extend(['--cc', 'true']) 153 ARGV.extend(['--cachePathMasks', 'false']) 155 ARGV.extend(['--allPathsVolatile', 'true']) 157 ARGV.extend(['--gpuThreads', str(FLAGS.gpuThreads)]) 159 ARGV.extend([' [all...] |
/third_party/skia/ |
H A D | PRESUBMIT.py | 270 results.extend(_CheckChangeHasEol( 273 results.extend(input_api.canned_checks.CheckChangeHasNoCR( 275 results.extend(input_api.canned_checks.CheckChangeHasNoStrayWhitespace( 277 results.extend(_JsonChecks(input_api, output_api)) 278 results.extend(_IfDefChecks(input_api, output_api)) 279 results.extend(_CopyrightChecks(input_api, output_api, 281 results.extend(_CheckDEPSValid(input_api, output_api)) 282 results.extend(_CheckIncludesFormatted(input_api, output_api)) 283 results.extend(_CheckGNFormatted(input_api, output_api)) 284 results.extend(_CheckGitConflictMarker [all...] |
/third_party/node/deps/v8/tools/mb/ |
H A D | PRESUBMIT.py | 16 results.extend(input_api.RunTests(pylint_checks)) 19 results.extend( 26 results.extend(input_api.RunTests([ 32 results.extend(
|