| /third_party/nghttp2/lib/ |
| D | nghttp2_queue.c | 30 void nghttp2_queue_init(nghttp2_queue *queue) { in nghttp2_queue_init()
34 void nghttp2_queue_free(nghttp2_queue *queue) { in nghttp2_queue_free()
47 int nghttp2_queue_push(nghttp2_queue *queue, void *data) { in nghttp2_queue_push()
65 void nghttp2_queue_pop(nghttp2_queue *queue) { in nghttp2_queue_pop()
75 void *nghttp2_queue_front(nghttp2_queue *queue) { in nghttp2_queue_front()
80 void *nghttp2_queue_back(nghttp2_queue *queue) { in nghttp2_queue_back()
85 int nghttp2_queue_empty(nghttp2_queue *queue) { return queue->front == NULL; } in nghttp2_queue_empty()
|
| /third_party/ffmpeg/libavfilter/ |
| D | bufferqueue.h | 50 AVFrame *queue[FF_BUFQUEUE_SIZE]; member
60 static inline int ff_bufqueue_is_full(struct FFBufQueue *queue) in ff_bufqueue_is_full()
71 static inline void ff_bufqueue_add(void *log, struct FFBufQueue *queue, in ff_bufqueue_add()
87 static inline AVFrame *ff_bufqueue_peek(struct FFBufQueue *queue, in ff_bufqueue_peek()
98 static inline AVFrame *ff_bufqueue_get(struct FFBufQueue *queue) in ff_bufqueue_get()
111 static inline void ff_bufqueue_discard_all(struct FFBufQueue *queue) in ff_bufqueue_discard_all()
|
| /third_party/mesa3d/src/gallium/drivers/virgl/ |
| D | virgl_transfer_queue.c | 140 virgl_transfer_queue_find_overlap(const struct virgl_transfer_queue *queue, in virgl_transfer_queue_find_overlap()
162 static void remove_transfer(struct virgl_transfer_queue *queue, in remove_transfer()
169 static void replace_unmapped_transfer(struct virgl_transfer_queue *queue, in replace_unmapped_transfer()
182 static void transfer_put(struct virgl_transfer_queue *queue, in transfer_put()
195 static void transfer_write(struct virgl_transfer_queue *queue, in transfer_write()
208 static void compare_and_perform_action(struct virgl_transfer_queue *queue, in compare_and_perform_action()
226 static void perform_action(struct virgl_transfer_queue *queue, in perform_action()
241 static void add_internal(struct virgl_transfer_queue *queue, in add_internal()
264 void virgl_transfer_queue_init(struct virgl_transfer_queue *queue, in virgl_transfer_queue_init()
282 void virgl_transfer_queue_fini(struct virgl_transfer_queue *queue) in virgl_transfer_queue_fini()
[all …]
|
| /third_party/mesa3d/src/util/ |
| D | u_queue.c | 82 add_to_atexit_list(struct util_queue *queue) in add_to_atexit_list()
92 remove_from_atexit_list(struct util_queue *queue) in remove_from_atexit_list()
242 struct util_queue *queue; member
249 struct util_queue *queue = ((struct thread_input*)input)->queue; in util_queue_thread_func() local
333 util_queue_create_thread(struct util_queue *queue, unsigned index) in util_queue_create_thread()
363 util_queue_adjust_num_threads(struct util_queue *queue, unsigned num_threads) in util_queue_adjust_num_threads()
398 util_queue_init(struct util_queue *queue, in util_queue_init()
489 util_queue_kill_threads(struct util_queue *queue, unsigned keep_num_threads, in util_queue_kill_threads()
528 util_queue_destroy(struct util_queue *queue) in util_queue_destroy()
545 util_queue_add_job(struct util_queue *queue, in util_queue_add_job()
[all …]
|
| D | u_vector.h | 65 u_vector_init(struct u_vector *queue, in u_vector_init()
75 u_vector_length(struct u_vector *queue) in u_vector_length()
96 u_vector_finish(struct u_vector *queue) in u_vector_finish()
107 #define u_vector_foreach(elem, queue) \ argument
|
| /third_party/skia/third_party/externals/dawn/src/tests/unittests/ |
| D | SerialQueueTests.cpp | 24 TestSerialQueue queue; in TEST() local
61 TestSerialQueue queue; in TEST() local
82 TestSerialQueue queue; in TEST() local
104 TestSerialQueue queue; in TEST() local
128 TestSerialQueue queue; in TEST() local
150 TestSerialQueue queue; in TEST() local
164 MySerialQueue queue; in TEST() local
|
| /third_party/mesa3d/src/vulkan/runtime/ |
| D | vk_queue.c | 50 vk_queue_init(struct vk_queue *queue, struct vk_device *device, in vk_queue_init()
114 _vk_queue_set_lost(struct vk_queue *queue, in _vk_queue_set_lost()
141 vk_queue_submit_alloc(struct vk_queue *queue, in vk_queue_submit_alloc()
210 vk_queue_submit_cleanup(struct vk_queue *queue, in vk_queue_submit_cleanup()
241 vk_queue_submit_free(struct vk_queue *queue, in vk_queue_submit_free()
248 vk_queue_submit_destroy(struct vk_queue *queue, in vk_queue_submit_destroy()
256 vk_queue_push_submit(struct vk_queue *queue, in vk_queue_push_submit()
266 vk_queue_drain(struct vk_queue *queue) in vk_queue_drain()
289 vk_queue_submit_final(struct vk_queue *queue, in vk_queue_submit_final()
396 vk_queue_flush(struct vk_queue *queue, uint32_t *submit_count_out) in vk_queue_flush()
[all …]
|
| D | vk_queue.h | 161 vk_queue_is_empty(struct vk_queue *queue) in vk_queue_is_empty()
185 #define vk_queue_set_lost(queue, ...) \ argument
189 vk_queue_is_lost(struct vk_queue *queue) in vk_queue_is_lost()
194 #define vk_foreach_queue(queue, device) \ argument
197 #define vk_foreach_queue_safe(queue, device) \ argument
|
| /third_party/skia/third_party/externals/harfbuzz/src/ |
| D | test-priority-queue.cc | 33 hb_priority_queue_t queue; in test_insert() local
56 hb_priority_queue_t queue; in test_extract() local
79 hb_priority_queue_t queue; in test_extract_empty() local
|
| /third_party/mesa3d/src/gallium/drivers/llvmpipe/ |
| D | lp_scene_queue.c | 74 struct lp_scene_queue *queue = CALLOC_STRUCT(lp_scene_queue); in lp_scene_queue_create() local
88 lp_scene_queue_destroy(struct lp_scene_queue *queue) in lp_scene_queue_destroy()
98 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait) in lp_scene_dequeue()
124 lp_scene_enqueue(struct lp_scene_queue *queue, struct lp_scene *scene) in lp_scene_enqueue()
|
| /third_party/mesa3d/src/broadcom/vulkan/ |
| D | v3dv_queue.c | 74 queue_wait_idle(struct v3dv_queue *queue, in queue_wait_idle()
127 handle_reset_query_cpu_job(struct v3dv_queue *queue, struct v3dv_job *job, in handle_reset_query_cpu_job()
169 export_perfmon_last_job_sync(struct v3dv_queue *queue, struct v3dv_job *job, int *fd) in export_perfmon_last_job_sync()
222 struct v3dv_queue *queue = &job->device->queue; in handle_end_query_cpu_job() local
293 handle_set_event_cpu_job(struct v3dv_queue *queue, struct v3dv_job *job, in handle_set_event_cpu_job()
347 handle_copy_buffer_to_image_cpu_job(struct v3dv_queue *queue, in handle_copy_buffer_to_image_cpu_job()
400 handle_timestamp_query_cpu_job(struct v3dv_queue *queue, struct v3dv_job *job, in handle_timestamp_query_cpu_job()
432 handle_csd_indirect_cpu_job(struct v3dv_queue *queue, in handle_csd_indirect_cpu_job()
465 process_waits(struct v3dv_queue *queue, in process_waits()
527 process_signals(struct v3dv_queue *queue, in process_signals()
[all …]
|
| /third_party/mesa3d/src/vulkan/wsi/ |
| D | wsi_common_queue.h | 38 wsi_queue_init(struct wsi_queue *queue, int length) in wsi_queue_init()
80 wsi_queue_destroy(struct wsi_queue *queue) in wsi_queue_destroy()
88 wsi_queue_push(struct wsi_queue *queue, uint32_t index) in wsi_queue_push()
107 wsi_queue_pull(struct wsi_queue *queue, uint32_t *index, uint64_t timeout) in wsi_queue_pull()
|
| /third_party/mesa3d/src/virtio/venus-protocol/ |
| D | vn_protocol_driver_queue.h | 1001 static inline size_t vn_sizeof_vkQueueSubmit(VkQueue queue, uint32_t submitCount, const VkSubmitInf… in vn_sizeof_vkQueueSubmit()
1021 …vkQueueSubmit(struct vn_cs_encoder *enc, VkCommandFlagsEXT cmd_flags, VkQueue queue, uint32_t subm… in vn_encode_vkQueueSubmit()
1040 static inline size_t vn_sizeof_vkQueueSubmit_reply(VkQueue queue, uint32_t submitCount, const VkSub… in vn_sizeof_vkQueueSubmit_reply()
1055 static inline VkResult vn_decode_vkQueueSubmit_reply(struct vn_cs_decoder *dec, VkQueue queue, uint… in vn_decode_vkQueueSubmit_reply()
1071 static inline size_t vn_sizeof_vkQueueWaitIdle(VkQueue queue) in vn_sizeof_vkQueueWaitIdle()
1082 …id vn_encode_vkQueueWaitIdle(struct vn_cs_encoder *enc, VkCommandFlagsEXT cmd_flags, VkQueue queue) in vn_encode_vkQueueWaitIdle()
1092 static inline size_t vn_sizeof_vkQueueWaitIdle_reply(VkQueue queue) in vn_sizeof_vkQueueWaitIdle_reply()
1104 static inline VkResult vn_decode_vkQueueWaitIdle_reply(struct vn_cs_decoder *dec, VkQueue queue) in vn_decode_vkQueueWaitIdle_reply()
1117 static inline size_t vn_sizeof_vkQueueBindSparse(VkQueue queue, uint32_t bindInfoCount, const VkBin… in vn_sizeof_vkQueueBindSparse()
1137 …eueBindSparse(struct vn_cs_encoder *enc, VkCommandFlagsEXT cmd_flags, VkQueue queue, uint32_t bind… in vn_encode_vkQueueBindSparse()
[all …]
|
| /third_party/python/Lib/test/ |
| D | _test_venv_multiprocessing.py | 6 def fill_queue(queue, code): argument
10 def drain_queue(queue, code): argument
|
| D | test_queue.py | 251 queue = py_queue variable in PyQueueTest
256 queue = c_queue variable in CQueueTest
267 queue = py_queue variable in PyLifoQueueTest
272 queue = c_queue variable in CLifoQueueTest
283 queue = py_queue variable in PyPriorityQueueTest
288 queue = c_queue variable in CPriorityQueueTest
413 queue = py_queue variable in PyFailingQueueTest
418 queue = c_queue variable in CFailingQueueTest
603 queue = py_queue variable in PySimpleQueueTest
612 queue = c_queue variable in CSimpleQueueTest
|
| /third_party/mesa3d/src/intel/vulkan/ |
| D | anv_queue.c | 31 anv_queue_init(struct anv_device *device, struct anv_queue *queue, in anv_queue_init()
69 anv_queue_finish(struct anv_queue *queue) in anv_queue_finish()
|
| /third_party/skia/third_party/externals/dawn/src/tests/unittests/validation/ |
| D | QueueSubmitValidationTests.cpp | 45 wgpu::Queue queue = device.GetQueue(); in TEST_F() local
87 wgpu::Queue queue = device.GetQueue(); in TEST_F() local
118 wgpu::Queue queue = device.GetQueue(); in TEST_F() local
151 wgpu::Queue queue = data->device.GetQueue(); in TEST_F() local
173 wgpu::Queue queue = data->device.GetQueue(); in TEST_F() local
208 wgpu::Queue queue = data->device.GetQueue(); in TEST_F() local
225 wgpu::Queue queue = device.GetQueue(); in TEST_F() local
295 wgpu::Queue queue = device.GetQueue(); in TEST_F() local
|
| /third_party/skia/third_party/externals/dawn/src/dawn_wire/server/ |
| D | ServerQueue.cpp | 32 auto* queue = QueueObjects().Get(queueId); in DoQueueOnSubmittedWorkDone() local
55 auto* queue = QueueObjects().Get(queueId); in DoQueueWriteBuffer() local
84 auto* queue = QueueObjects().Get(queueId); in DoQueueWriteTexture() local
|
| /third_party/mesa3d/src/panfrost/vulkan/ |
| D | panvk_vX_device.c | 39 panvk_queue_submit_batch(struct panvk_queue *queue, in panvk_queue_submit_batch()
125 panvk_queue_transfer_sync(struct panvk_queue *queue, uint32_t syncobj) in panvk_queue_transfer_sync()
168 panvk_signal_event_syncobjs(struct panvk_queue *queue, struct panvk_batch *batch) in panvk_signal_event_syncobjs()
203 struct panvk_queue *queue = in panvk_per_arch() local
|
| /third_party/ffmpeg/libavformat/ |
| D | movenchint.c | 70 static void sample_queue_pop(HintSampleQueue *queue) in sample_queue_pop()
83 static void sample_queue_free(HintSampleQueue *queue) in sample_queue_free()
99 static void sample_queue_push(HintSampleQueue *queue, const uint8_t *data, int size, in sample_queue_push()
125 static void sample_queue_retain(HintSampleQueue *queue) in sample_queue_retain()
216 HintSampleQueue *queue, int *pos, in find_sample_match()
284 HintSampleQueue *queue) in describe_payload()
|
| /third_party/mesa3d/src/intel/ds/ |
| D | intel_driver_ds.cc | 194 struct intel_ds_queue *queue; in send_descriptors() local
262 begin_event(struct intel_ds_queue *queue, uint64_t ts_ns, in begin_event()
278 end_event(struct intel_ds_queue *queue, uint64_t ts_ns, in end_event()
447 intel_ds_begin_submit(struct intel_ds_queue *queue) in intel_ds_begin_submit()
453 intel_ds_end_submit(struct intel_ds_queue *queue, in intel_ds_end_submit()
547 struct intel_ds_queue *queue = in intel_ds_device_add_queue() local
569 struct intel_ds_queue *queue, in intel_ds_flush_data_init()
|
| /third_party/mesa3d/src/gallium/drivers/svga/ |
| D | svga_state_tss.c | 82 struct bind_queue *queue) in emit_tex_binding_unit()
150 struct bind_queue queue; in update_tss_binding() local
241 struct bind_queue queue; in svga_reemit_tss_bindings() local
359 struct ts_queue *queue) in emit_tss_unit()
388 struct ts_queue queue; in update_tss() local
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_close/ |
| D | 2-1.c | 98 mqd_t queue; in parent_process() local
158 mqd_t queue; in child_process() local
207 mqd_t queue; in open_queue() local
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/plugin/device/cpu/hal/hardware/ |
| D | ms_collective_topo.cc | 97 auto &queue = iter->second; in Finalize() local
148 auto queue = this->received_messages_[rank_id]; in Receive() local
171 std::queue<MessageBase *> *queue = nullptr; in HandleMessage() local
|
| /third_party/mesa3d/src/imagination/vulkan/ |
| D | pvr_queue.c | 58 struct pvr_queue *queue, in pvr_queue_init()
148 static void pvr_queue_finish(struct pvr_queue *queue) in pvr_queue_finish()
194 struct pvr_queue *queue, in pvr_process_graphics_cmd()
283 struct pvr_queue *queue, in pvr_process_compute_cmd()
324 struct pvr_queue *queue, in pvr_process_transfer_cmds()
458 struct pvr_queue *queue, in pvr_process_cmd_buffer()
|