Searched refs:g_async_queue_length (Results 1 – 14 of 14) sorted by relevance
76 len = g_async_queue_length (async_queue); in sort_queue()81 len = g_async_queue_length (async_queue); in sort_queue()123 len = g_async_queue_length (async_queue); in enter_thread()
367 if (g_async_queue_length (queue_output_buf) > 3) { in on_new_sample()481 if (g_async_queue_length (queue_input_buf) > 3) { in sdl_event_loop()489 while (g_async_queue_length (queue_input_buf) > 3) { in sdl_event_loop()639 while (g_async_queue_length (queue_input_buf) > 0) { in main()646 while (g_async_queue_length (queue_output_buf) > 0) { in main()
90 g_assert_cmpint (g_async_queue_length (q), ==, 4); in test_async_queue_destroy()158 g_assert_cmpint (g_async_queue_length (q), ==, 0); in test_async_queue_threads()
88 gint g_async_queue_length (GAsyncQueue *queue);
849 unprocessed = g_async_queue_length (real->queue); in g_thread_pool_unprocessed()892 g_async_queue_length (real->queue) == 0); in g_thread_pool_free()
678 g_async_queue_length (GAsyncQueue *queue) in g_async_queue_length() function
579 push_size = g_async_queue_length (s_q.push_queue); in GST_START_TEST()593 g_async_queue_length (s_q.wait_queue)); in GST_START_TEST()
330 g_assert (g_async_queue_length (data.cancellable_source_queue) == 0); in test_cancellable_source_threaded_dispose()
1016 g_assert_cmpint (g_async_queue_length (data.incoming_queue), ==, 0); in test_connection_filter()1033 g_assert_cmpint (g_async_queue_length (data.incoming_queue), ==, 0); in test_connection_filter()
1821 return g_async_queue_length (priv->buffer_queue); in gst_harness_buffers_in_queue()2081 return g_async_queue_length (priv->sink_event_queue); in gst_harness_events_in_queue()2184 return g_async_queue_length (priv->src_event_queue); in gst_harness_upstream_events_in_queue()
1029 while ((g_async_queue_length (vtdec->reorder_queue) >= in gst_vtdec_push_frames_if_needed()
1133 return g_async_queue_length (connection->output_queue); in gst_rtmp_connection_get_num_queued()
1172 g_async_queue_length
1328 g_assert (g_async_queue_length (nvenc->bitstream_queue) == 0); in gst_nv_base_enc_start_bitstream_thread()