Searched refs:num_queued (Results 1 – 10 of 10) sorted by relevance
283 assert(queue->num_queued >= 0 && queue->num_queued <= queue->max_jobs); in util_queue_thread_func()286 while (thread_index < queue->num_threads && queue->num_queued == 0) in util_queue_thread_func()299 queue->num_queued--; in util_queue_thread_func()326 queue->num_queued = 0; in util_queue_thread_func()444 queue->num_queued = 0; in util_queue_init()566 assert(queue->num_queued >= 0 && queue->num_queued <= queue->max_jobs); in util_queue_add_job()569 if (queue->num_queued > 0 && in util_queue_add_job()576 if (queue->num_queued == queue->max_jobs) { in util_queue_add_job()597 assert(num_jobs == queue->num_queued); in util_queue_add_job()606 while (queue->num_queued == queue->max_jobs) in util_queue_add_job()[all …]
214 int num_queued; member
676 guint num_queued; in gst_v4l2_buffer_pool_streamon() local679 num_queued = g_atomic_int_get (&pool->num_queued); in gst_v4l2_buffer_pool_streamon()680 if (num_queued < pool->num_allocated) in gst_v4l2_buffer_pool_streamon()681 n = pool->num_allocated - num_queued; in gst_v4l2_buffer_pool_streamon()761 g_atomic_int_add (&pool->num_queued, -1); in gst_v4l2_buffer_pool_streamoff()909 pool->num_queued = 0; in gst_v4l2_buffer_pool_start()924 if (g_atomic_int_get (&pool->num_queued) < pool->num_allocated) in gst_v4l2_buffer_pool_start()1248 g_atomic_int_inc (&pool->num_queued); in gst_v4l2_buffer_pool_qbuf()1278 g_atomic_int_add (&pool->num_queued, -1); in gst_v4l2_buffer_pool_qbuf()1339 if (g_atomic_int_dec_and_test (&pool->num_queued)) { in gst_v4l2_buffer_pool_dqbuf()[all …]
88 guint num_queued; /* number of buffers queued in the driver */ member
775 guint num_queued; in GST_START_TEST() local795 num_queued = 0; in GST_START_TEST()803 num_queued++; in GST_START_TEST()810 fail_unless (num_queued > 0); in GST_START_TEST()816 while (num_queued > 0) { in GST_START_TEST()822 num_queued -= message_sent_count; in GST_START_TEST()823 fail_unless (num_queued >= 0); in GST_START_TEST()
2151 int num_queued = 0; in sctp_asconf_iterator_stcb() local2304 num_queued++; in sctp_asconf_iterator_stcb()2312 if (num_queued > 0) { in sctp_asconf_iterator_stcb()
13540 unsigned int num_queued; member
14761 …<var-decl name="num_queued" type-id="f0981eeb" visibility="default" filepath="include/linux/dynami…27374 …<var-decl name="num_queued" type-id="f0981eeb" visibility="default" filepath="include/linux/dynami…
14761 …<var-decl name="num_queued" type-id="f0981eeb" visibility="default" filepath="include/linux/dynami…27346 …<var-decl name="num_queued" type-id="f0981eeb" visibility="default" filepath="include/linux/dynami…
49974 v4l2bufferpool: Prevent num_queued from going negative62757 Don't just loop over the first num_queued buffers but loop over