Lines Matching refs:event_queue

267   object->event_queue =  in gst_rtp_dtmf_src_init()
281   if (dtmfsrc->event_queue) {  in gst_rtp_dtmf_src_finalize()
282     g_async_queue_unref (dtmfsrc->event_queue);  in gst_rtp_dtmf_src_finalize()
283     dtmfsrc->event_queue = NULL;  in gst_rtp_dtmf_src_finalize()
518   g_async_queue_push (dtmfsrc->event_queue, event);  in gst_rtp_dtmf_src_add_start_event()
528   g_async_queue_push (dtmfsrc->event_queue, event);  in gst_rtp_dtmf_src_add_stop_event()
670       event = g_async_queue_pop (dtmfsrc->event_queue);  in gst_rtp_dtmf_src_create()
705             g_async_queue_push (dtmfsrc->event_queue, event);  in gst_rtp_dtmf_src_create()
717       event = g_async_queue_try_pop (dtmfsrc->event_queue);  in gst_rtp_dtmf_src_create()
748               g_async_queue_push (dtmfsrc->event_queue, event);  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()
1126   g_async_queue_push (dtmfsrc->event_queue, event);  in gst_rtp_dtmf_src_unlock()