| /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
191 GST_CAT_LOG_OBJECT (queue_dataflow, queue, \
196 queue->cur_level.buffers, \
197 queue->max_level.buffers, \
198 queue->cur_level.bytes, \
199 queue->max_level.bytes, \
[all …]
|
| D | gstqueue.c | 82 #define STATUS(queue, pad, msg) \ argument
83 GST_CAT_LOG_OBJECT (queue_dataflow, queue, \
88 queue->cur_level.buffers, \
89 queue->min_threshold.buffers, \
90 queue->max_size.buffers, \
91 queue->cur_level.bytes, \
92 queue->min_threshold.bytes, \
93 queue->max_size.bytes, \
94 queue->cur_level.time, \
95 queue->min_threshold.time, \
[all …]
|
| /third_party/mesa3d/src/util/ |
| D | u_queue.c | 47 util_queue_kill_threads(struct util_queue *queue, unsigned keep_num_threads,
82 add_to_atexit_list(struct util_queue *queue) in add_to_atexit_list() argument
87 list_add(&queue->head, &queue_list); in add_to_atexit_list()
92 remove_from_atexit_list(struct util_queue *queue) in remove_from_atexit_list() argument
98 if (iter == 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
254 if (queue->flags & UTIL_QUEUE_INIT_SET_FULL_THREAD_AFFINITY) { in util_queue_thread_func()
267 if (queue->flags & UTIL_QUEUE_INIT_USE_MINIMUM_PRIORITY) { in util_queue_thread_func()
273 if (strlen(queue->name) > 0) { in util_queue_thread_func()
[all …]
|
| D | u_vector.h | 57 int u_vector_init_pow2(struct u_vector *queue,
61 void *u_vector_add(struct u_vector *queue);
62 void *u_vector_remove(struct u_vector *queue);
65 u_vector_init(struct u_vector *queue, in u_vector_init() argument
71 return u_vector_init_pow2(queue, initial_element_count, element_size); in u_vector_init()
75 u_vector_length(struct u_vector *queue) in u_vector_length() argument
77 return (queue->head - queue->tail) / queue->element_size; in u_vector_length()
96 u_vector_finish(struct u_vector *queue) in u_vector_finish() argument
98 free(queue->data); in u_vector_finish()
107 #define u_vector_foreach(elem, queue) \ argument
[all …]
|
| /third_party/gstreamer/gstreamer/libs/gst/base/ |
| D | gstdataqueue.c | 66 GstQueueArray *queue; member
111 queue, \
115 gst_queue_array_get_length (q->priv->queue))
194 gst_data_queue_init (GstDataQueue * queue) in gst_data_queue_init() argument
196 queue->priv = gst_data_queue_get_instance_private (queue); in gst_data_queue_init()
198 queue->priv->cur_level.visible = 0; /* no content */ in gst_data_queue_init()
199 queue->priv->cur_level.bytes = 0; /* no content */ in gst_data_queue_init()
200 queue->priv->cur_level.time = 0; /* no content */ in gst_data_queue_init()
202 queue->priv->checkfull = NULL; in gst_data_queue_init()
204 g_mutex_init (&queue->priv->qlock); in gst_data_queue_init()
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-priority-queue.js | 11 const queue = new PriorityQueue(); constant
13 queue.insert(i);
16 assert.strictEqual(queue.peek(), i);
17 assert.strictEqual(queue.shift(), i);
20 assert.strictEqual(queue.shift(), undefined);
24 queue.insert(i);
27 assert.strictEqual(queue.shift(), i);
30 assert.strictEqual(queue.shift(), undefined);
35 const queue = new PriorityQueue(); constant
37 queue.insert(i);
[all …]
|
| D | test-fixed-queue.js | 10 const queue = new FixedQueue(); constant
11 assert.strictEqual(queue.head, queue.tail);
12 assert(queue.isEmpty());
13 queue.push('a');
14 assert(!queue.isEmpty());
15 assert.strictEqual(queue.shift(), 'a');
16 assert.strictEqual(queue.shift(), null);
20 const queue = new FixedQueue(); constant
22 queue.push('a');
23 assert(queue.head.isFull());
[all …]
|
| /third_party/skia/third_party/externals/dawn/src/tests/unittests/ |
| D | SerialQueueTests.cpp | 24 TestSerialQueue queue; in TEST() local
27 ASSERT_TRUE(queue.Empty()); in TEST()
30 for (int value : queue.IterateAll()) { in TEST()
36 queue.Enqueue(1, 0); in TEST()
37 queue.Enqueue(2, 0); in TEST()
38 queue.Enqueue(std::move(3), 1); in TEST()
42 for (int value : queue.IterateAll()) { in TEST()
50 queue.Clear(); in TEST()
51 ASSERT_TRUE(queue.Empty()); in TEST()
53 for (int value : queue.IterateAll()) { in TEST()
[all …]
|
| /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
76 if (!queue) in lp_scene_queue_create()
79 (void) mtx_init(&queue->mutex, mtx_plain); in lp_scene_queue_create()
80 cnd_init(&queue->change); in lp_scene_queue_create()
82 return queue; in lp_scene_queue_create()
88 lp_scene_queue_destroy(struct lp_scene_queue *queue) in lp_scene_queue_destroy() argument
90 cnd_destroy(&queue->change); in lp_scene_queue_destroy()
91 mtx_destroy(&queue->mutex); in lp_scene_queue_destroy()
92 FREE(queue); in lp_scene_queue_destroy()
98 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait) in lp_scene_dequeue() argument
[all …]
|
| /third_party/mesa3d/src/vulkan/runtime/ |
| D | vk_queue.c | 47 vk_queue_start_submit_thread(struct vk_queue *queue);
50 vk_queue_init(struct vk_queue *queue, struct vk_device *device, in vk_queue_init() argument
57 memset(queue, 0, sizeof(*queue)); in vk_queue_init()
58 vk_object_base_init(device, &queue->base, VK_OBJECT_TYPE_QUEUE); in vk_queue_init()
60 list_addtail(&queue->link, &device->queues); in vk_queue_init()
62 queue->flags = pCreateInfo->flags; in vk_queue_init()
63 queue->queue_family_index = pCreateInfo->queueFamilyIndex; in vk_queue_init()
66 queue->index_in_family = index_in_family; in vk_queue_init()
68 queue->submit.mode = device->submit_mode; in vk_queue_init()
69 if (queue->submit.mode == VK_QUEUE_SUBMIT_MODE_THREADED_ON_DEMAND) in vk_queue_init()
[all …]
|
| /third_party/skia/third_party/externals/harfbuzz/src/ |
| D | test-priority-queue.cc | 33 hb_priority_queue_t queue; in test_insert() local
34 assert (queue.is_empty ()); in test_insert()
36 queue.insert (10, 0); in test_insert()
37 assert (!queue.is_empty ()); in test_insert()
38 assert (queue.minimum () == hb_pair (10, 0)); in test_insert()
40 queue.insert (20, 1); in test_insert()
41 assert (queue.minimum () == hb_pair (10, 0)); in test_insert()
43 queue.insert (5, 2); in test_insert()
44 assert (queue.minimum () == hb_pair (5, 2)); in test_insert()
46 queue.insert (15, 3); in test_insert()
[all …]
|
| /third_party/gstreamer/gstreamer/gst/ |
| D | gstatomicqueue.c | 116 add_to_free_list (GstAtomicQueue * queue, GstAQueueMem * mem) in add_to_free_list() argument
119 mem->free = g_atomic_pointer_get (&queue->free_list); in add_to_free_list()
120 } while (!g_atomic_pointer_compare_and_exchange (&queue->free_list, in add_to_free_list()
125 clear_free_list (GstAtomicQueue * queue) in clear_free_list() argument
131 free_list = g_atomic_pointer_get (&queue->free_list); in clear_free_list()
134 } while (!g_atomic_pointer_compare_and_exchange (&queue->free_list, free_list, in clear_free_list()
158 GstAtomicQueue *queue; in gst_atomic_queue_new() local
160 queue = g_new (GstAtomicQueue, 1); in gst_atomic_queue_new()
162 queue->refcount = 1; in gst_atomic_queue_new()
164 queue->num_readers = 0; in gst_atomic_queue_new()
[all …]
|
| /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() argument
68 GstVulkanQueuePrivate *priv = GET_PRIV (queue); in gst_vulkan_queue_init()
84 GstVulkanQueue *queue = GST_VULKAN_QUEUE (object); in gst_vulkan_queue_dispose() local
85 GstVulkanQueuePrivate *priv = GET_PRIV (queue); in gst_vulkan_queue_dispose()
87 if (queue->device) in gst_vulkan_queue_dispose()
88 gst_object_unref (queue->device); in gst_vulkan_queue_dispose()
89 queue->device = NULL; in gst_vulkan_queue_dispose()
105 gst_vulkan_queue_get_device (GstVulkanQueue * queue) in gst_vulkan_queue_get_device() argument
107 g_return_val_if_fail (GST_IS_VULKAN_QUEUE (queue), NULL); in gst_vulkan_queue_get_device()
[all …]
|
| /third_party/ffmpeg/libavfilter/ |
| D | bufferqueue.h | 50 AVFrame *queue[FF_BUFQUEUE_SIZE]; member
55 #define BUCKET(i) queue->queue[(queue->head + (i)) % FF_BUFQUEUE_SIZE]
60 static inline int ff_bufqueue_is_full(struct FFBufQueue *queue) in ff_bufqueue_is_full() argument
62 return queue->available == FF_BUFQUEUE_SIZE; in ff_bufqueue_is_full()
71 static inline void ff_bufqueue_add(void *log, struct FFBufQueue *queue, in ff_bufqueue_add() argument
74 if (ff_bufqueue_is_full(queue)) { in ff_bufqueue_add()
76 av_frame_free(&BUCKET(--queue->available)); in ff_bufqueue_add()
78 BUCKET(queue->available++) = buf; in ff_bufqueue_add()
87 static inline AVFrame *ff_bufqueue_peek(struct FFBufQueue *queue, in ff_bufqueue_peek() argument
90 return index < queue->available ? BUCKET(index) : NULL; in ff_bufqueue_peek()
[all …]
|
| /third_party/gstreamer/gstplugins_good/gst/rtpmanager/ |
| D | rtptimerqueue.c | 178 rtp_timer_queue_get_tail (RtpTimerQueue * queue) in rtp_timer_queue_get_tail() argument
180 return (RtpTimer *) queue->timers.tail; in rtp_timer_queue_get_tail()
184 rtp_timer_queue_set_tail (RtpTimerQueue * queue, RtpTimer * timer) in rtp_timer_queue_set_tail() argument
186 queue->timers.tail = (GList *) timer; in rtp_timer_queue_set_tail()
187 g_assert (queue->timers.tail->next == NULL); in rtp_timer_queue_set_tail()
191 rtp_timer_queue_get_head (RtpTimerQueue * queue) in rtp_timer_queue_get_head() argument
193 return (RtpTimer *) queue->timers.head; in rtp_timer_queue_get_head()
197 rtp_timer_queue_set_head (RtpTimerQueue * queue, RtpTimer * timer) in rtp_timer_queue_set_head() argument
199 queue->timers.head = (GList *) timer; in rtp_timer_queue_set_head()
200 g_assert (queue->timers.head->prev == NULL); in rtp_timer_queue_set_head()
[all …]
|
| /third_party/mesa3d/src/gallium/drivers/virgl/ |
| D | virgl_transfer_queue.c | 44 typedef void (*list_action_t)(struct virgl_transfer_queue *queue,
140 virgl_transfer_queue_find_overlap(const struct virgl_transfer_queue *queue, in virgl_transfer_queue_find_overlap() argument
147 LIST_FOR_EACH_ENTRY(xfer, &queue->transfer_list, queue_link) { in virgl_transfer_queue_find_overlap()
162 static void remove_transfer(struct virgl_transfer_queue *queue, in remove_transfer() argument
166 virgl_resource_destroy_transfer(queue->vctx, queued); in remove_transfer()
169 static void replace_unmapped_transfer(struct virgl_transfer_queue *queue, in replace_unmapped_transfer() argument
178 remove_transfer(queue, queued); in replace_unmapped_transfer()
179 queue->num_dwords -= (VIRGL_TRANSFER3D_SIZE + 1); in replace_unmapped_transfer()
182 static void transfer_put(struct virgl_transfer_queue *queue, in transfer_put() argument
187 queue->vs->vws->transfer_put(queue->vs->vws, queued->hw_res, in transfer_put()
[all …]
|
| /third_party/node/deps/nghttp2/lib/ |
| D | nghttp2_queue.c | 30 void nghttp2_queue_init(nghttp2_queue *queue) { in nghttp2_queue_init() argument
31 queue->front = queue->back = NULL; in nghttp2_queue_init()
34 void nghttp2_queue_free(nghttp2_queue *queue) { in nghttp2_queue_free() argument
35 if (!queue) { in nghttp2_queue_free()
38 nghttp2_queue_cell *p = queue->front; in nghttp2_queue_free()
47 int nghttp2_queue_push(nghttp2_queue *queue, void *data) { in nghttp2_queue_push() argument
55 if (queue->back) { in nghttp2_queue_push()
56 queue->back->next = new_cell; in nghttp2_queue_push()
57 queue->back = new_cell; in nghttp2_queue_push()
60 queue->front = queue->back = new_cell; in nghttp2_queue_push()
[all …]
|
| /third_party/nghttp2/lib/ |
| D | nghttp2_queue.c | 30 void nghttp2_queue_init(nghttp2_queue *queue) { in nghttp2_queue_init() argument
31 queue->front = queue->back = NULL; in nghttp2_queue_init()
34 void nghttp2_queue_free(nghttp2_queue *queue) { in nghttp2_queue_free() argument
35 if (!queue) { in nghttp2_queue_free()
38 nghttp2_queue_cell *p = queue->front; in nghttp2_queue_free()
47 int nghttp2_queue_push(nghttp2_queue *queue, void *data) { in nghttp2_queue_push() argument
55 if (queue->back) { in nghttp2_queue_push()
56 queue->back->next = new_cell; in nghttp2_queue_push()
57 queue->back = new_cell; in nghttp2_queue_push()
60 queue->front = queue->back = new_cell; in nghttp2_queue_push()
[all …]
|
| /third_party/gstreamer/gstplugins_good/tests/check/elements/ |
| D | rtptimerqueue.c | 27 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
30 rtp_timer_queue_set_timer (queue, RTP_TIMER_EXPECTED, 10, in GST_START_TEST()
32 timer10 = rtp_timer_queue_find (queue, 10); in GST_START_TEST()
44 rtp_timer_queue_set_timer (queue, RTP_TIMER_LOST, 0, in GST_START_TEST()
46 timer0 = rtp_timer_queue_find (queue, 0); in GST_START_TEST()
63 g_object_unref (queue); in GST_START_TEST()
70 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
73 rtp_timer_queue_set_deadline (queue, 1, -1, 0); in GST_START_TEST()
74 rtp_timer_queue_set_deadline (queue, 3, -1, 0); in GST_START_TEST()
75 rtp_timer_queue_set_deadline (queue, 2, -1, 0); in GST_START_TEST()
[all …]
|
| /third_party/benchmark/test/ |
| D | benchmark_random_interleaving_gtest.cc | 20 class EventQueue : public std::queue<std::string> {
37 EventQueue* queue = new EventQueue(); variable
47 static void SetupHook(int /* num_threads */) { queue->push("Setup"); } in SetupHook()
49 static void TeardownHook(int /* num_threads */) { queue->push("Teardown"); } in TeardownHook()
52 queue->Clear(); in Execute()
59 queue->Put("DONE"); // End marker in Execute()
68 queue->Put(StrFormat("BM_Match1/%d", static_cast<int>(arg))); in BM_Match1()
81 ASSERT_EQ("BM_Match1/1", queue->Get()); in TEST_F()
82 ASSERT_EQ("BM_Match1/2", queue->Get()); in TEST_F()
83 ASSERT_EQ("BM_Match1/3", queue->Get()); in TEST_F()
[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() argument
45 ret = u_vector_init(&queue->vector, length, sizeof(uint32_t)); in wsi_queue_init()
58 ret = pthread_cond_init(&queue->cond, &condattr); in wsi_queue_init()
62 ret = pthread_mutex_init(&queue->mutex, NULL); in wsi_queue_init()
70 pthread_cond_destroy(&queue->cond); in wsi_queue_init()
74 u_vector_finish(&queue->vector); in wsi_queue_init()
80 wsi_queue_destroy(struct wsi_queue *queue) in wsi_queue_destroy() argument
82 u_vector_finish(&queue->vector); in wsi_queue_destroy()
83 pthread_mutex_destroy(&queue->mutex); in wsi_queue_destroy()
84 pthread_cond_destroy(&queue->cond); in wsi_queue_destroy()
[all …]
|
| /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() argument
39 result = vk_queue_init(&queue->vk, &device->vk, pCreateInfo, in anv_queue_init()
47 0, 0, &queue->sync); in anv_queue_init()
49 vk_queue_finish(&queue->vk); in anv_queue_init()
54 queue->vk.driver_submit = anv_queue_submit; in anv_queue_init()
56 queue->device = device; in anv_queue_init()
58 assert(queue->vk.queue_family_index < pdevice->queue.family_count); in anv_queue_init()
59 queue->family = &pdevice->queue.families[queue->vk.queue_family_index]; in anv_queue_init()
61 queue->index_in_family = index_in_family; in anv_queue_init()
63 queue->exec_flags = exec_flags; in anv_queue_init()
[all …]
|
| /third_party/ffmpeg/libavformat/ |
| D | movenchint.c | 70 static void sample_queue_pop(HintSampleQueue *queue) in sample_queue_pop() argument
72 if (queue->len <= 0) in sample_queue_pop()
74 if (queue->samples[0].own_data) in sample_queue_pop()
75 av_freep(&queue->samples[0].data); in sample_queue_pop()
76 queue->len--; in sample_queue_pop()
77 memmove(queue->samples, queue->samples + 1, sizeof(HintSample)*queue->len); in sample_queue_pop()
83 static void sample_queue_free(HintSampleQueue *queue) in sample_queue_free() argument
86 for (i = 0; i < queue->len; i++) in sample_queue_free()
87 if (queue->samples[i].own_data) in sample_queue_free()
88 av_freep(&queue->samples[i].data); in sample_queue_free()
[all …]
|
| /third_party/mesa3d/src/broadcom/vulkan/ |
| D | v3dv_queue.c | 74 queue_wait_idle(struct v3dv_queue *queue, in queue_wait_idle() argument
77 if (queue->device->pdevice->caps.multisync) { in queue_wait_idle()
78 int ret = drmSyncobjWait(queue->device->pdevice->render_fd, in queue_wait_idle()
79 queue->last_job_syncs.syncs, 3, in queue_wait_idle()
83 return vk_errorf(queue, VK_ERROR_DEVICE_LOST, in queue_wait_idle()
89 if (!queue->last_job_syncs.first[i]) in queue_wait_idle()
98 VkResult result = vk_sync_wait_many(&queue->device->vk, in queue_wait_idle()
110 int ret = drmSyncobjWait(queue->device->pdevice->render_fd, in queue_wait_idle()
111 &queue->last_job_syncs.syncs[V3DV_QUEUE_ANY], 1, in queue_wait_idle()
115 return vk_errorf(queue, VK_ERROR_DEVICE_LOST, in queue_wait_idle()
[all …]
|
| /third_party/gstreamer/gstreamer/tests/check/elements/ |
| D | queue.c | 33 static GstElement *queue; variable
64 queue_overrun (GstElement * queue, gpointer user_data) in queue_overrun() argument
71 queue_underrun (GstElement * queue, gpointer user_data) in queue_underrun() argument
99 qsrcpad = gst_element_get_static_pad (queue, "src"); in block_src()
116 queue = gst_check_setup_element ("queue"); in setup()
117 g_signal_connect (queue, "underrun", G_CALLBACK (queue_underrun), NULL); in setup()
119 mysrcpad = gst_check_setup_src_pad (queue, &srctemplate); in setup()
152 gst_check_teardown_sink_pad (queue); in cleanup()
156 gst_check_teardown_src_pad (queue); in cleanup()
158 gst_check_teardown_element (queue); in cleanup()
[all …]
|