| /third_party/gstreamer/gstplugins_good/gst/rtpmanager/ |
| D | rtptimerqueue.c | 178 rtp_timer_queue_get_tail (RtpTimerQueue * queue) in rtp_timer_queue_get_tail()
184 rtp_timer_queue_set_tail (RtpTimerQueue * queue, RtpTimer * timer) in rtp_timer_queue_set_tail()
191 rtp_timer_queue_get_head (RtpTimerQueue * queue) in rtp_timer_queue_get_head()
197 rtp_timer_queue_set_head (RtpTimerQueue * queue, RtpTimer * timer) in rtp_timer_queue_set_head()
204 rtp_timer_queue_insert_before (RtpTimerQueue * queue, RtpTimer * sibling, in rtp_timer_queue_insert_before()
221 rtp_timer_queue_insert_after (RtpTimerQueue * queue, RtpTimer * sibling, in rtp_timer_queue_insert_after()
238 rtp_timer_queue_insert_tail (RtpTimerQueue * queue, RtpTimer * timer) in rtp_timer_queue_insert_tail()
264 rtp_timer_queue_insert_head (RtpTimerQueue * queue, RtpTimer * timer) in rtp_timer_queue_insert_head()
292 rtp_timer_queue_init (RtpTimerQueue * queue) in rtp_timer_queue_init()
300 RtpTimerQueue *queue = RTP_TIMER_QUEUE (object); in rtp_timer_queue_finalize() local
[all …]
|
| /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/node/deps/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/gstreamer/gstplugins_bad/gst-libs/gst/vulkan/ |
| D | gstvkqueue.c | 61 #define GET_PRIV(queue) gst_vulkan_queue_get_instance_private (queue) argument
66 gst_vulkan_queue_init (GstVulkanQueue * queue) in gst_vulkan_queue_init()
84 GstVulkanQueue *queue = GST_VULKAN_QUEUE (object); in gst_vulkan_queue_dispose() local
105 gst_vulkan_queue_get_device (GstVulkanQueue * queue) in gst_vulkan_queue_get_device()
122 gst_vulkan_queue_create_command_pool (GstVulkanQueue * queue, GError ** error) in gst_vulkan_queue_create_command_pool()
167 gst_context_set_vulkan_queue (GstContext * context, GstVulkanQueue * queue) in gst_context_set_vulkan_queue()
194 gst_context_get_vulkan_queue (GstContext * context, GstVulkanQueue ** queue) in gst_context_get_vulkan_queue()
229 GstVulkanQueue * queue) in gst_vulkan_queue_handle_context_query()
276 GstVulkanQueue ** queue) in gst_vulkan_queue_run_context_query()
318 gst_vulkan_queue_submit_lock (GstVulkanQueue * queue) in gst_vulkan_queue_submit_lock()
[all …]
|
| /third_party/gstreamer/gstreamer/libs/gst/base/ |
| D | gstdataqueue.c | 66 GstQueueArray *queue; member
194 gst_data_queue_init (GstDataQueue * queue) in gst_data_queue_init()
249 gst_data_queue_cleanup (GstDataQueue * queue) in gst_data_queue_cleanup()
268 GstDataQueue *queue = GST_DATA_QUEUE (object); in gst_data_queue_finalize() local
287 gst_data_queue_locked_flush (GstDataQueue * queue) in gst_data_queue_locked_flush()
300 gst_data_queue_locked_is_empty (GstDataQueue * queue) in gst_data_queue_locked_is_empty()
308 gst_data_queue_locked_is_full (GstDataQueue * queue) in gst_data_queue_locked_is_full()
327 gst_data_queue_flush (GstDataQueue * queue) in gst_data_queue_flush()
347 gst_data_queue_is_empty (GstDataQueue * queue) in gst_data_queue_is_empty()
371 gst_data_queue_is_full (GstDataQueue * queue) in gst_data_queue_is_full()
[all …]
|
| /third_party/flutter/skia/third_party/externals/sdl/visualtest/src/ |
| D | action_configparser.c | 43 SDLVisualTest_EnqueueAction(SDLVisualTest_ActionQueue* queue, in SDLVisualTest_EnqueueAction()
74 SDLVisualTest_DequeueAction(SDLVisualTest_ActionQueue* queue) in SDLVisualTest_DequeueAction()
105 SDLVisualTest_InitActionQueue(SDLVisualTest_ActionQueue* queue) in SDLVisualTest_InitActionQueue()
118 SDLVisualTest_GetQueueFront(SDLVisualTest_ActionQueue* queue) in SDLVisualTest_GetQueueFront()
135 SDLVisualTest_IsActionQueueEmpty(SDLVisualTest_ActionQueue* queue) in SDLVisualTest_IsActionQueueEmpty()
149 SDLVisualTest_EmptyActionQueue(SDLVisualTest_ActionQueue* queue) in SDLVisualTest_EmptyActionQueue()
161 SortQueue(SDLVisualTest_ActionQueue* queue) in SortQueue()
201 SDLVisualTest_InsertIntoActionQueue(SDLVisualTest_ActionQueue* queue, in SDLVisualTest_InsertIntoActionQueue()
259 SDLVisualTest_ParseActionConfig(char* file, SDLVisualTest_ActionQueue* queue) in SDLVisualTest_ParseActionConfig()
|
| /third_party/gstreamer/gstreamer/plugins/elements/ |
| D | gstqueue2.c | 109 #define QUEUE_IS_USING_TEMP_FILE(queue) ((queue)->temp_template != NULL) argument
110 #define QUEUE_IS_USING_RING_BUFFER(queue) ((queue)->ring_buffer_max_size != 0) /* for consistency … argument
111 #define QUEUE_IS_USING_QUEUE(queue) (!QUEUE_IS_USING_TEMP_FILE(queue) && !QUEUE_IS_USING_RING_BUFFE… argument
113 #define QUEUE_MAX_BYTES(queue) MIN((queue)->max_level.bytes, (queue)->ring_buffer_max_size) argument
190 #define STATUS(queue, pad, msg) \ argument
489 gst_queue2_init (GstQueue2 * queue) in gst_queue2_init()
576 GstQueue2 *queue = GST_QUEUE2 (object); in gst_queue2_finalize() local
604 debug_ranges (GstQueue2 * queue) in debug_ranges()
620 clean_ranges (GstQueue2 * queue) in clean_ranges()
631 find_range (GstQueue2 * queue, guint64 offset) in find_range()
[all …]
|
| D | gstqueue.c | 82 #define STATUS(queue, pad, msg) \ argument
429 gst_queue_init (GstQueue * queue) in gst_queue_init()
489 GstQueue *queue = GST_QUEUE (object); in gst_queue_finalize() local
529 update_time_level (GstQueue * queue) in update_time_level()
564 apply_segment (GstQueue * queue, GstEvent * event, GstSegment * segment, in apply_segment()
591 apply_gap (GstQueue * queue, GstEvent * event, in apply_gap()
620 apply_buffer (GstQueue * queue, GstBuffer * buffer, GstSegment * segment, in apply_buffer()
677 apply_buffer_list (GstQueue * queue, GstBufferList * buffer_list, in apply_buffer_list()
702 gst_queue_locked_flush (GstQueue * queue, gboolean full) in gst_queue_locked_flush()
738 gst_queue_locked_enqueue_buffer (GstQueue * queue, gpointer item) in gst_queue_locked_enqueue_buffer()
[all …]
|
| /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/gstreamer/gstplugins_good/tests/check/elements/ |
| D | rtptimerqueue.c | 27 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
70 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
123 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
213 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
240 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
264 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
285 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
|
| /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/gstreamer/gstreamer/gst/ |
| D | gstatomicqueue.c | 116 add_to_free_list (GstAtomicQueue * queue, GstAQueueMem * mem) in add_to_free_list()
125 clear_free_list (GstAtomicQueue * queue) in clear_free_list()
158 GstAtomicQueue *queue; in gst_atomic_queue_new() local
179 gst_atomic_queue_ref (GstAtomicQueue * queue) in gst_atomic_queue_ref()
187 gst_atomic_queue_free (GstAtomicQueue * queue) in gst_atomic_queue_free()
203 gst_atomic_queue_unref (GstAtomicQueue * queue) in gst_atomic_queue_unref()
221 gst_atomic_queue_peek (GstAtomicQueue * queue) in gst_atomic_queue_peek()
271 gst_atomic_queue_pop (GstAtomicQueue * queue) in gst_atomic_queue_pop()
338 gst_atomic_queue_push (GstAtomicQueue * queue, gpointer data) in gst_atomic_queue_push()
400 gst_atomic_queue_length (GstAtomicQueue * queue) in gst_atomic_queue_length()
|
| /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 …]
|
| /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/flutter/skia/third_party/externals/dawn/src/tests/unittests/ |
| D | SerialQueueTests.cpp | 23 TestSerialQueue queue; in TEST() local
60 TestSerialQueue queue; in TEST() local
81 TestSerialQueue queue; in TEST() local
103 TestSerialQueue queue; in TEST() local
127 TestSerialQueue queue; in TEST() local
149 TestSerialQueue queue; in TEST() local
|
| /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/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/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/node/test/parallel/ |
| D | test-priority-queue.js | 11 const queue = new PriorityQueue(); constant
35 const queue = new PriorityQueue(); constant
48 const queue = new PriorityQueue((a, b) => b - a); constant
64 const queue = new PriorityQueue((a, b) => { constant
79 const queue = new PriorityQueue((a, b) => { constant
117 const queue = new PriorityQueue((a, b) => { constant
|
| /third_party/gstreamer/gstplugins_bad/ext/curl/ |
| D | gstcurlqueue.c | 59 gst_curl_http_src_add_queue_item (GstCurlHttpSrcQueueElement ** queue, in gst_curl_http_src_add_queue_item()
127 gst_curl_http_src_remove_queue_item (GstCurlHttpSrcQueueElement ** queue, in gst_curl_http_src_remove_queue_item()
174 gst_curl_http_src_remove_queue_handle (GstCurlHttpSrcQueueElement ** queue, in gst_curl_http_src_remove_queue_handle()
|
| /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 …]
|