Searched refs:g_async_queue_new (Results 1 – 13 of 13) sorted by relevance
46 q = g_async_queue_new (); in test_async_queue_sort()133 q = g_async_queue_new (); in test_async_queue_threads()184 q = g_async_queue_new (); in test_async_queue_timed()230 q = g_async_queue_new (); in test_async_queue_remove()253 q = g_async_queue_new (); in test_async_queue_push_front()
47 g_autoptr(GAsyncQueue) val = g_async_queue_new (); in test_g_async_queue()
574 retval->queue = g_async_queue_new (); in g_thread_pool_new()586 unused_thread_queue = g_async_queue_new (); in g_thread_pool_new()618 spawn_thread_queue = g_async_queue_new (); in g_thread_pool_new()
39 GAsyncQueue *g_async_queue_new (void);
119 g_async_queue_new (void) in g_async_queue_new() function
606 queue_input_buf = g_async_queue_new (); in main()607 queue_output_buf = g_async_queue_new (); in main()
190 async_queue = g_async_queue_new (); in main()
543 s_q.push_queue = g_async_queue_new (); in GST_START_TEST()544 s_q.wait_queue = g_async_queue_new (); in GST_START_TEST()
146 pending_buffers = g_async_queue_new (); in start_pipeline()
720 nvenc->available_queue = g_async_queue_new (); in gst_nv_base_enc_start()721 nvenc->pending_queue = g_async_queue_new (); in gst_nv_base_enc_start()722 nvenc->bitstream_queue = g_async_queue_new (); in gst_nv_base_enc_start()
196 vtdec->reorder_queue = g_async_queue_new (); in gst_vtdec_init()
685 self->cur_outframes = g_async_queue_new (); in gst_vtenc_start()
1161 g_async_queue_new