Home
last modified time | relevance | path

Searched refs:extend (Results 1 - 25 of 89) sorted by relevance

1234

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dvirtual_cloud_db.cpp35 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 Dvirtual_cloud_db.h27 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 Ddistributeddb_cloud_syncer_download_assets_test.cpp141 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...]
H A Ddistributeddb_cloud_syncer_lock_test.cpp116 int64_t begin, int64_t count, int64_t gidStart, std::vector<VBucket> &record, std::vector<VBucket> &extend);
208 int64_t begin, int64_t count, int64_t gidStart, std::vector<VBucket> &record, std::vector<VBucket> &extend) in GenerateDataRecords()
230 extend.push_back(log); in GenerateDataRecords()
239 std::vector<VBucket> extend; in InsertLocalData() local
240 GenerateDataRecords(begin, count, 0, record, extend); in InsertLocalData()
266 std::vector<VBucket> extend; in InsertCloudDBData() local
267 GenerateDataRecords(begin, count, gidStart, record, extend); in InsertCloudDBData()
268 ASSERT_EQ(g_virtualCloudDb->BatchInsertWithGid(tableName, std::move(record), extend), DBStatus::OK); in InsertCloudDBData()
277 std::vector<VBucket> extend; in UpdateCloudDBData() local
278 GenerateDataRecords(begin, count, gidStart, record, extend); in UpdateCloudDBData()
207 GenerateDataRecords( int64_t begin, int64_t count, int64_t gidStart, std::vector<VBucket> &record, std::vector<VBucket> &extend) GenerateDataRecords() argument
290 std::vector<VBucket> extend; DeleteCloudDBData() local
413 std::vector<VBucket> extend; UpdateCloudAssets() local
633 VBucket extend; HWTEST_F() local
[all...]
H A Ddistributeddb_cloud_syncer_upload_test.cpp106 uploadData.insData.extend = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataInsData()
114 uploadData.updData.extend = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataUpdData()
124 uploadData.insData.extend = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataForUploadModeCheck012()
127 uploadData.delData.extend = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataForUploadModeCheck012()
406 uploadData.insData.extend = std::vector<VBucket>(1001, tmp); in HWTEST_F()
472 uploadData3.insData.extend = std::vector<VBucket>(1001, tmp); in HWTEST_F()
528 uploadData2.insData.extend = std::vector<VBucket>(100); in HWTEST_F()
588 // CloudSyncData format error: record does not match extend length in HWTEST_F()
591 uploadData.insData.extend = std::vector<VBucket>(999, tmp); in HWTEST_F()
642 uploadData2.insData.extend in HWTEST_F()
[all...]
/foundation/multimedia/image_framework/frameworks/innerkitsimpl/common/src/
H A Dmemory_manager.cpp120 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 Drdb_cloud.cpp35 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 Drdb_cloud.h44 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,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_sync_utils.cpp219 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 Dcloud_db_proxy.cpp96 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 Dcloud_db_proxy.h43 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...]
H A Dcloud_sync_utils.h69 static int GetWaterMarkAndUpdateTime(std::vector<VBucket>& extend, Timestamp &waterMark);
86 static bool IsSkipAssetsMissingRecord(const std::vector<VBucket> &extend);
90 static int FillAssetIdToAssetData(const Type &extend, Type &assetData);
92 static void FillAssetIdToAssetsData(const Assets &extend, Assets &assets);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/cloud/
H A Dicloud_db.h31 ** param[in & out] extend: will fill gid after insert ok
34 std::vector<VBucket> &extend) = 0;
36 std::vector<VBucket> &extend) = 0;
37 virtual DBStatus BatchDelete(const std::string &tableName, std::vector<VBucket> &extend) = 0;
41 virtual DBStatus Query(const std::string &tableName, VBucket &extend, std::vector<VBucket> &data) = 0;
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/c_adapter/
H A Dcloud_extension.rs281 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...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/
H A Dcloud_db.cpp18 int32_t CloudDB::Execute(const std::string &table, const std::string &sql, const VBucket &extend) in Execute() argument
43 std::shared_ptr<Cursor> CloudDB::Query(const std::string &table, const VBucket &extend) in Query() argument
48 std::shared_ptr<Cursor> CloudDB::Query(GenQuery &query, const VBucket &extend) in Query() argument
53 int32_t CloudDB::PreSharing(const std::string &table, VBuckets &extend) in PreSharing() argument
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/include/
H A Dcloud_extension.h170 * extend [IN/OUT] HashMap<String, Value>
177 OhCloudExtHashMap *extend
186 * extend [IN/OUT] Vec<HashMap<String, Value>>
194 OhCloudExtVector *extend
203 * extend [IN/OUT] Vec<HashMap<String, Value>>
211 OhCloudExtVector *extend
220 * extend [IN/OUT] Vec<HashMap<String, Value>>
227 const OhCloudExtVector *extend
/foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/text/
H A Dtext_base.cpp30 const std::wstring& text, int32_t extend, bool checkPrev) in GetGraphemeClusterLength()
34 if (static_cast<size_t>(extend) <= text.length()) { in GetGraphemeClusterLength()
35 aroundChar = text[std::max(0, extend - 1)]; in GetGraphemeClusterLength()
38 if (static_cast<size_t>(extend) <= (text.length())) { in GetGraphemeClusterLength()
39 aroundChar = text[std::min(text.length() ? static_cast<int32_t>(text.length()) - 1 : 0, extend)]; in GetGraphemeClusterLength()
29 GetGraphemeClusterLength( const std::wstring& text, int32_t extend, bool checkPrev) GetGraphemeClusterLength() argument
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/
H A Dcloud_db.h33 virtual int32_t Execute(const std::string &table, const std::string &sql, const VBucket &extend);
43 virtual std::shared_ptr<Cursor> Query(const std::string &table, const VBucket &extend);
45 virtual std::shared_ptr<Cursor> Query(GenQuery &query, const VBucket &extend);
47 virtual int32_t PreSharing(const std::string &table, VBuckets &extend);
/foundation/arkui/ace_engine/frameworks/core/components/text_overlay/
H A Dtext_overlay_manager.cpp374 int32_t TextOverlayBase::GetGraphemeClusterLength(int32_t extend, bool isPrefix) const argument
379 if (static_cast<size_t>(extend) <= text.length()) {
380 aroundChar = text[std::max(0, extend - 1)];
383 if (static_cast<size_t>(extend) < (text.length())) {
384 aroundChar = text[std::min(text.length() ? static_cast<int32_t>(text.length()) - 1 : 0, extend)];
515 int32_t extend = GetCursorPositionForClick(pos, globalOffset); local
516 int32_t extendEnd = extend + GetGraphemeClusterLength(extend, false);
517 textValue_.UpdateSelection(extend, extendEnd);
522 int32_t extend local
528 int32_t extend = GetCursorPositionForClick(pos, globalOffset); global() local
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/
H A Dcloud_db_impl.cpp37 int32_t CloudDbImpl::Execute(const std::string &table, const std::string &sql, const DBVBucket &extend) in Execute() argument
45 auto data = ExtensionUtil::Convert(extend); in Execute()
122 std::shared_ptr<DBCursor> CloudDbImpl::Query(const std::string &table, const DBVBucket &extend) in Query() argument
125 auto it = extend.find(DistributedData::SchemaMeta::CURSOR_FIELD); in Query()
126 if (it != extend.end()) { in Query()
H A Dcloud_db_impl.h34 int32_t Execute(const std::string &table, const std::string &sql, const DBVBucket &extend) override;
39 std::shared_ptr<DBCursor> Query(const std::string &table, const DBVBucket &extend) override;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_assets_operation_sync_test.cpp254 std::vector<VBucket> extend; in UpdateCloudTableRecord() local
278 extend.push_back(log); in UpdateCloudTableRecord()
281 ASSERT_EQ(virtualCloudDb_->BatchUpdate(tableName_, std::move(record), extend), DBStatus::OK); in UpdateCloudTableRecord()
502 virtualCloudDb_->ForkUpload([&isUpload](const std::string &tableName, VBucket &extend) { in HWTEST_F()
1015 VBucket extend; in HWTEST_F() local
1016 extend[CloudDbConstant::CURSOR_FIELD] = std::string(""); in HWTEST_F()
1018 ASSERT_EQ(virtualCloudDb_->Query(tableName_, extend, data), QUERY_END); in HWTEST_F()
1062 virtualCloudDb_->ForkUpload([&tempAsset, &recordIndex](const std::string &tableName, VBucket &extend) { in HWTEST_F()
1067 extend[std::string(CloudDbConstant::ERROR_FIELD)] = static_cast<int64_t>(DBStatus::CLOUD_ERROR); in HWTEST_F()
1070 extend[st in HWTEST_F()
[all...]
/foundation/filemanagement/storage_service/services/storage_daemon/include/utils/
H A Dhi_audit.h35 std::string extend; member
40 "operationStatus, operationCount, extend\n"; in TitleString()
46 ", " + operationStatus + ", " + std::to_string(operationCount) + ", " + extend; in ToString()
/foundation/ability/idl_tool/idl_tool_2/
H A Dbuild_hdi_files_info.py494 ModuleInfo.sources.extend(sources)
495 ModuleInfo.proxy_sources.extend(proxy_sources)
496 ModuleInfo.stub_sources.extend(sub_sources)
681 sources.extend([header_file, service_header_file, service_source_file, driver_source_file])
698 sources.extend([header_file, service_header_file, service_source_file, driver_source_file])
714 sources.extend([header_file, source_file])
727 sources.extend([
755 sources.extend(
759 sources.extend(
762 sources.extend(
[all...]
/foundation/multimedia/image_framework/frameworks/innerkitsimpl/common/include/
H A Dmemory_manager.h42 MemoryData extend; member in OHOS::Media::AbsMemory
78 static std::unique_ptr<AbsMemory> CreateMemory(AllocatorType type, MemoryData &data, MemoryData &extend);

Completed in 16 milliseconds

1234