Home
last modified time | relevance | path

Searched refs:batch (Results 1 - 19 of 19) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/kv/
H A Dgrd_kv_api.cpp116 GRD_API int32_t GRD_KVBatchPrepare(uint16_t itemNum, GRD_KVBatchT **batch) in GRD_KVBatchPrepare() argument
124 return GRD_KVApiInfo.KVBatchPrepareApi(itemNum, batch); in GRD_KVBatchPrepare()
128 GRD_KVBatchT *batch) in GRD_KVBatchPushback()
136 return GRD_KVApiInfo.KVBatchPushbackApi(key, keyLen, data, dataLen, batch); in GRD_KVBatchPushback()
139 GRD_API int32_t GRD_KVBatchPut(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch) in GRD_KVBatchPut() argument
147 return GRD_KVApiInfo.KVBatchPutApi(db, collectionName, batch); in GRD_KVBatchPut()
150 GRD_API int32_t GRD_KVBatchDel(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch) in GRD_KVBatchDel() argument
158 return GRD_KVApiInfo.KVBatchDelApi(db, collectionName, batch); in GRD_KVBatchDel()
161 GRD_API int32_t GRD_KVBatchDestroy(GRD_KVBatchT *batch) in GRD_KVBatchDestroy() argument
169 return GRD_KVApiInfo.KVBatchDestoryApi(batch); in GRD_KVBatchDestroy()
127 GRD_KVBatchPushback(const void *key, uint32_t keyLen, const void *data, uint32_t dataLen, GRD_KVBatchT *batch) GRD_KVBatchPushback() argument
[all...]
H A Dgrd_kv_api_inner.cpp65 int32_t GRD_KVBatchPrepareInner(uint16_t itemNum, GRD_KVBatchT **batch) in GRD_KVBatchPrepareInner() argument
71 GRD_KVBatchT *batch) in GRD_KVBatchPushbackInner()
76 int32_t GRD_KVBatchPutInner(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch) in GRD_KVBatchPutInner() argument
81 int32_t GRD_KVBatchDelInner(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch) in GRD_KVBatchDelInner() argument
86 int32_t GRD_KVBatchDestroyInner(GRD_KVBatchT *batch) in GRD_KVBatchDestroyInner() argument
70 GRD_KVBatchPushbackInner(const void *key, uint32_t keyLen, const void *data, uint32_t dataLen, GRD_KVBatchT *batch) GRD_KVBatchPushbackInner() argument
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/include/
H A Dgrd_kv_api_inner.h43 int32_t GRD_KVBatchPrepareInner(uint16_t itemNum, GRD_KVBatchT **batch);
46 GRD_KVBatchT *batch);
48 int32_t GRD_KVBatchPutInner(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch);
50 int32_t GRD_KVBatchDelInner(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch);
52 int32_t GRD_KVBatchDestroyInner(GRD_KVBatchT *batch);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_utils.h65 int RdKVBatchPrepare(uint16_t itemNum, GRD_KVBatchT **batch);
67 int RdKVBatchPushback(GRD_KVBatchT *batch, const Key &key, const Value &value);
69 int RdKVBatchPut(GRD_DB *db, const char *kvTableName, GRD_KVBatchT *batch);
74 int RdKVBatchDel(GRD_DB *db, const char *kvTableName, GRD_KVBatchT *batch);
76 int RdKVBatchDestroy(GRD_KVBatchT *batch);
H A Drd_utils.cpp230 int RdKVBatchPrepare(uint16_t itemNum, GRD_KVBatchT **batch) in RdKVBatchPrepare() argument
232 return TransferGrdErrno(GRD_KVBatchPrepare(itemNum, batch)); in RdKVBatchPrepare()
235 int RdKVBatchPushback(GRD_KVBatchT *batch, const Key &key, const Value &value) in RdKVBatchPushback() argument
240 GRD_KVBatchPushback(innerKey.data, innerKey.dataLen, innerVal.data, innerVal.dataLen, batch)); in RdKVBatchPushback()
247 int RdKVBatchPut(GRD_DB *db, const char *kvTableName, GRD_KVBatchT *batch) in RdKVBatchPut() argument
253 return TransferGrdErrno(GRD_KVBatchPut(db, kvTableName, batch)); in RdKVBatchPut()
266 int RdKVBatchDel(GRD_DB *db, const char *kvTableName, GRD_KVBatchT *batch) in RdKVBatchDel() argument
272 return TransferGrdErrno(GRD_KVBatchDel(db, kvTableName, batch)); in RdKVBatchDel()
275 int RdKVBatchDestroy(GRD_KVBatchT *batch) in RdKVBatchDestroy() argument
277 return TransferGrdErrno(GRD_KVBatchDestroy(batch)); in RdKVBatchDestroy()
[all...]
H A Drd_single_ver_storage_executor.cpp395 GRD_KVBatchT *batch = nullptr; in BatchSaveEntries() local
396 int ret = RdKVBatchPrepare(entries.size(), &batch); in BatchSaveEntries()
402 ret = RdKVBatchPushback(batch, entry.key, entry.value); in BatchSaveEntries()
404 (void)RdKVBatchDestroy(batch); in BatchSaveEntries()
414 (void)RdKVBatchDestroy(batch); in BatchSaveEntries()
418 ret = RdKVBatchDel(db_, SYNC_COLLECTION_NAME, batch); in BatchSaveEntries()
420 ret = RdKVBatchPut(db_, SYNC_COLLECTION_NAME, batch); in BatchSaveEntries()
423 (void)RdKVBatchDestroy(batch); in BatchSaveEntries()
431 int errCode = RdKVBatchDestroy(batch); in BatchSaveEntries()
433 LOGE("[RdSingleVerStorageExecutor][BatchSaveEntries] Can not destroy batch in BatchSaveEntries()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/include/grd_kv/
H A Dgrd_kv_api.h45 GRD_API int32_t GRD_KVBatchPrepare(uint16_t itemNum, GRD_KVBatchT **batch);
48 GRD_KVBatchT *batch);
50 GRD_API int32_t GRD_KVBatchPut(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch);
52 GRD_API int32_t GRD_KVBatchDel(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch);
54 GRD_API int32_t GRD_KVBatchDestroy(GRD_KVBatchT *batch);
/foundation/multimodalinput/input/service/event_resample/src/
H A Devent_resample.cpp61 // Add event into batch in OnEventConsume()
154 Batch& batch = batches_.at(batchIndex); in UpdateBatch() local
155 if (CanAddSample(batch, inputEvent_)) { in UpdateBatch()
156 batch.samples.push_back(inputEvent_); in UpdateBatch()
157 MMI_HILOGD("Event added to batch, deviceId:%{public}d, sourceType:%{public}d, pointerAction:%{public}d", in UpdateBatch()
163 // Start a new batch in UpdateBatch()
165 Batch batch; in UpdateBatch() local
166 batch.samples.push_back(inputEvent_); in UpdateBatch()
167 batches_.push_back(std::move(batch)); in UpdateBatch()
240 Batch& batch in ConsumeBatch() local
273 ConsumeSamples(Batch& batch, size_t count, MotionEvent** outEvent) ConsumeSamples() argument
466 CanAddSample(const Batch &batch, MotionEvent &event) CanAddSample() argument
494 FindSampleNoLaterThan(const Batch& batch, int64_t time) FindSampleNoLaterThan() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/common/include/
H A Dgrd_api_manager.h54 typedef int32_t (*KVBatchPrepare)(uint16_t itemNum, GRD_KVBatchT **batch);
56 GRD_KVBatchT *batch);
57 typedef int32_t (*KVBatchPut)(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch);
58 typedef int32_t (*KVBatchDel)(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch);
59 typedef int32_t (*KVBatchDestory)(GRD_KVBatchT *batch);
/foundation/ai/neural_network_runtime/example/deep_learning_framework/tflite/delegates/nnrt_delegate/
H A Dnnrt_utils.h118 const int32_t batch = dims[DEPTHWISE_WEIGHT_BATCH_DIMENSION]; in TransposeTensor() local
125 for (int32_t n = 0; n < batch; ++n) { in TransposeTensor()
126 int32_t newPos = c * (height * width) * batch + j * batch + n; in TransposeTensor()
/foundation/multimodalinput/input/service/event_resample/include/
H A Devent_resample.h251 ErrCode ConsumeSamples(Batch& batch, size_t count, MotionEvent** outEvent);
259 bool CanAddSample(const Batch &batch, MotionEvent &event);
261 ssize_t FindSampleNoLaterThan(const Batch& batch, int64_t time);
/foundation/distributedhardware/device_manager/utils/src/kvadapter/
H A Dkv_adapter.cpp221 auto batch = std::vector<std::string>(keys.begin() + i, keys.begin() + end); in DeleteBatch() local
223 for (auto item : batch) { in DeleteBatch()
/foundation/graphic/graphic_3d/lume/Lume_3D/src/ecs/systems/
H A Drender_preprocessor_system.h95 CORE_NS::Entity batch; member
H A Danimation_system.cpp755 // For each track batch reset the target properties to initial values, wait for trackValues_ to be filled and start in Update()
1058 auto batch = [this](size_t i, size_t offset, size_t count) { in ResetToInitialTrackValues() local
1059 // Wait that initial values for this track batch have been filled in ResetToInitialTrackValues()
1071 batch(i, i * taskSize_, taskSize_); in ResetToInitialTrackValues()
1074 batch(tasks_, tasks_ * taskSize_, remaining_); in ResetToInitialTrackValues()
1086 auto batch = [this](size_t i, size_t offset, size_t count) { in WriteUpdatedTrackValues() local
1087 // Wait for animation task for this batch to finish. in WriteUpdatedTrackValues()
1094 batch(i, i * taskSize_, taskSize_); in WriteUpdatedTrackValues()
1097 batch(tasks_, tasks_ * taskSize_, remaining_); in WriteUpdatedTrackValues()
H A Drender_preprocessor_system.cpp306 // could offer two lists of mesh+world, one containing the render mesh batch style meshes and second in GatherSortData()
493 // reorder the list so that entities with render mesh batch are first sorted by entity id in Update()
495 [](const SortData& value) { return EntityUtil::IsValid(value.batch); }); in Update()
527 // pos points to the first element where comparison failed i.e. pos is the last of previous batch in Update()
528 // and pos+1 is the first of the next batch in Update()
531 // if the batch size is 1, move the single entry to the end in Update()
/foundation/deviceprofile/device_info_manager/services/core/src/persistenceadapter/kvadapter/
H A Dkv_adapter.cpp377 auto batch = std::vector<std::string>(keys.begin() + i, keys.begin() + end); in DeleteBatch() local
379 for (auto item : batch) { in DeleteBatch()
/foundation/multimodalinput/input/service/event_resample/test/
H A Devent_resample_test.cpp214 // Consume samples in batch in CalculateExpected()
909 EventResample::Batch batch; in HWTEST_F() local
910 batch.samples.push_back(motionEvent); in HWTEST_F()
911 EventResampleHdr->batches_.push_back(batch); in HWTEST_F()
/foundation/graphic/graphic_surface/surface/include/
H A Dbuffer_queue.h168 void SetBatchHandle(bool batch);
/foundation/graphic/graphic_surface/surface/src/
H A Dbuffer_queue.cpp282 void BufferQueue::SetBatchHandle(bool batch) in SetBatchHandle() argument
285 isBatch_ = batch; in SetBatchHandle()

Completed in 16 milliseconds