Searched refs:g_async_queue_try_pop (Results 1 – 14 of 14) sorted by relevance
63 g_assert_null (g_async_queue_try_pop (q)); in test_async_queue_sort()243 g_assert_null (g_async_queue_try_pop (q)); in test_async_queue_remove()266 g_assert_null (g_async_queue_try_pop (q)); in test_async_queue_push_front()
695 event = g_async_queue_try_pop (dtmfsrc->event_queue); in gst_dtmf_src_create()901 event = g_async_queue_try_pop (dtmfsrc->event_queue); in gst_dtmf_src_change_state()906 event = g_async_queue_try_pop (dtmfsrc->event_queue); in gst_dtmf_src_change_state()928 event = g_async_queue_try_pop (dtmfsrc->event_queue); in gst_dtmf_src_change_state()933 event = g_async_queue_try_pop (dtmfsrc->event_queue); in gst_dtmf_src_change_state()
717 event = g_async_queue_try_pop (dtmfsrc->event_queue); in gst_rtp_dtmf_src_create()1057 while ((event = g_async_queue_try_pop (dtmfsrc->event_queue)) != NULL) { in gst_rtp_dtmf_src_change_state()1081 while ((event = g_async_queue_try_pop (dtmfsrc->event_queue)) != NULL) { in gst_rtp_dtmf_src_change_state()
161 while ((buf = g_async_queue_try_pop (pending_buffers))) in stop_pipeline()169 while ((buf = g_async_queue_try_pop (pending_buffers))) in stop_pipeline()
78 gpointer g_async_queue_try_pop (GAsyncQueue *queue);
489 g_async_queue_try_pop (GAsyncQueue *queue) in g_async_queue_try_pop() function
153 item = g_async_queue_try_pop (q); in basic_tests()
582 while ((item = g_async_queue_try_pop (s_q.push_queue))) { in GST_START_TEST()595 while ((item = g_async_queue_try_pop (s_q.wait_queue))) { in GST_START_TEST()
1722 *buf = g_async_queue_try_pop (priv->buffer_queue); in gst_harness_pull_until_eos()1751 GstBuffer *buf = (GstBuffer *) g_async_queue_try_pop (priv->buffer_queue); in gst_harness_try_pull()2041 return (GstEvent *) g_async_queue_try_pop (priv->sink_event_queue); in gst_harness_try_pull_event()2144 return (GstEvent *) g_async_queue_try_pop (priv->src_event_queue); in gst_harness_try_pull_upstream_event()
661 while ((outframe = g_async_queue_try_pop (self->cur_outframes))) { in gst_vtenc_finish_encoding()1710 while ((outframe = g_async_queue_try_pop (self->cur_outframes))) { in gst_vtenc_encode_frame()
1031 frame = (GstVideoCodecFrame *) g_async_queue_try_pop (vtdec->reorder_queue); in gst_vtdec_push_frames_if_needed()
1393 while ((ptr = g_async_queue_try_pop (nvenc->available_queue))) { in gst_nv_base_enc_reset_queues()1396 while ((ptr = g_async_queue_try_pop (nvenc->pending_queue))) { in gst_nv_base_enc_reset_queues()1399 while ((ptr = g_async_queue_try_pop (nvenc->bitstream_queue))) { in gst_nv_base_enc_reset_queues()
528 message = g_async_queue_try_pop (self->output_queue); in gst_rtmp_connection_start_write()
1170 g_async_queue_try_pop