Home
last modified time | relevance | path

Searched refs:queue_index (Results 1 – 10 of 10) sorted by relevance

/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/source/
Dtf_reader_op.cc178 int32_t queue_index = 0; in FillIOBlockShuffle() local
197 RETURN_IF_NOT_OK(PushIoBlockQueue(queue_index, std::move(ioBlock))); in FillIOBlockShuffle()
198 queue_index = (queue_index + 1) % num_workers_; in FillIOBlockShuffle()
205 RETURN_IF_NOT_OK(PushIoBlockQueue(queue_index, std::move(ioBlock))); in FillIOBlockShuffle()
207 queue_index = (queue_index + 1) % num_workers_; in FillIOBlockShuffle()
220 RETURN_IF_NOT_OK(PostEndOfEpoch(queue_index)); in FillIOBlockShuffle()
225 int32_t queue_index = 0; in FillIOBlockNoShuffle() local
246 RETURN_IF_NOT_OK(PushIoBlockQueue(queue_index, std::move(ioBlock))); in FillIOBlockNoShuffle()
247 queue_index = (queue_index + 1) % num_workers_; in FillIOBlockNoShuffle()
253 RETURN_IF_NOT_OK(PushIoBlockQueue(queue_index, std::move(ioBlock))); in FillIOBlockNoShuffle()
[all …]
Dtext_file_op.cc123 int32_t queue_index = 0; in FillIOBlockQueue() local
153 RETURN_IF_NOT_OK(PushIoBlockQueue(queue_index, std::move(ioBlock))); in FillIOBlockQueue()
154 queue_index = (queue_index + 1) % num_workers_; in FillIOBlockQueue()
167 RETURN_IF_NOT_OK(PostEndOfEpoch(queue_index)); in FillIOBlockQueue()
Dclue_op.cc162 int32_t queue_index = 0; in FillIOBlockQueue() local
192 RETURN_IF_NOT_OK(PushIoBlockQueue(queue_index, std::move(ioBlock))); in FillIOBlockQueue()
193 queue_index = (queue_index + 1) % num_workers_; in FillIOBlockQueue()
206 RETURN_IF_NOT_OK(PostEndOfEpoch(queue_index)); in FillIOBlockQueue()
Dusps_op.cc291 int32_t queue_index = 0; in FillIOBlockQueue() local
321 RETURN_IF_NOT_OK(PushIoBlockQueue(queue_index, std::move(ioBlock))); in FillIOBlockQueue()
322 queue_index = (queue_index + 1) % num_workers_; in FillIOBlockQueue()
335 RETURN_IF_NOT_OK(PostEndOfEpoch(queue_index)); in FillIOBlockQueue()
Dnonmappable_leaf_op.cc172 Status NonMappableLeafOp::PostEndOfEpoch(int32_t queue_index) { in PostEndOfEpoch() argument
175 RETURN_IF_NOT_OK(PushIoBlockQueue((queue_index + i) % num_workers_, std::move(eoe))); in PostEndOfEpoch()
Dcsv_op.cc517 int32_t queue_index = 0; in FillIOBlockQueue() local
547 RETURN_IF_NOT_OK(PushIoBlockQueue(queue_index, std::move(ioBlock))); in FillIOBlockQueue()
548 queue_index = (queue_index + 1) % num_workers_; in FillIOBlockQueue()
561 RETURN_IF_NOT_OK(PostEndOfEpoch(queue_index)); in FillIOBlockQueue()
Dnonmappable_leaf_op.h97 Status PostEndOfEpoch(int32_t queue_index);
/third_party/mesa3d/src/virtio/vulkan/
Dvn_device.c36 uint32_t queue_index) in vn_queue_init() argument
47 .queueIndex = queue_index, in vn_queue_init()
53 queue->index = queue_index; in vn_queue_init()
/third_party/mesa3d/src/amd/vulkan/
Dradv_radeon_winsys.h276 VkResult (*cs_submit)(struct radeon_winsys_ctx *ctx, int queue_index,
/third_party/mesa3d/src/vulkan/overlay-layer/
Doverlay.cpp434 uint32_t queue_index = 0; in device_map_queues() local
444 data->queues[queue_index++] = in device_map_queues()