Lines Matching refs:num_queued
676 guint num_queued; in gst_v4l2_buffer_pool_streamon() local
679 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()
1355 GST_TIME_ARGS (timestamp), pool->num_queued, outbuf, old_buffer_state); in gst_v4l2_buffer_pool_dqbuf()
1970 guint num_queued; in gst_v4l2_buffer_pool_process() local
1981 num_queued = g_atomic_int_get (&pool->num_queued); in gst_v4l2_buffer_pool_process()
1983 num_queued); in gst_v4l2_buffer_pool_process()
1986 if (num_queued == 0) { in gst_v4l2_buffer_pool_process()
1995 if (num_queued < pool->copy_threshold) { in gst_v4l2_buffer_pool_process()
2173 g_atomic_int_add (&pool->num_queued, -1); in gst_v4l2_buffer_pool_process()
2189 if (g_atomic_int_get (&pool->num_queued) >= pool->min_latency) { in gst_v4l2_buffer_pool_process()