Home
last modified time | relevance | path

Searched refs:buffer_queue (Results 1 – 10 of 10) sorted by relevance

/third_party/gstreamer/gstplugins_bad/ext/kate/
Dgstkateparse.c234 while (parse->buffer_queue->length) { in gst_kate_parse_clear_queue()
237 buf = GST_BUFFER_CAST (g_queue_pop_head (parse->buffer_queue)); in gst_kate_parse_clear_queue()
285 while (!g_queue_is_empty (parse->buffer_queue)) { in gst_kate_parse_drain_queue_prematurely()
289 buf = GST_BUFFER_CAST (g_queue_pop_head (parse->buffer_queue)); in gst_kate_parse_drain_queue_prematurely()
298 g_assert (g_queue_is_empty (parse->buffer_queue)); in gst_kate_parse_drain_queue_prematurely()
309 if (!g_queue_is_empty (parse->buffer_queue)) { in gst_kate_parse_drain_queue()
311 buf = GST_BUFFER_CAST (g_queue_pop_head (parse->buffer_queue)); in gst_kate_parse_drain_queue()
317 g_assert (g_queue_is_empty (parse->buffer_queue)); in gst_kate_parse_drain_queue()
334 g_queue_push_tail (parse->buffer_queue, buf); in gst_kate_parse_queue_buffer()
607 parse->buffer_queue = g_queue_new (); in gst_kate_parse_change_state()
[all …]
Dgstkateparse.h61 GQueue *buffer_queue; member
/third_party/libsoup/libsoup/
Dsoup-cache-input-stream.c39 GQueue *buffer_queue; member
69 if (priv->current_writing_buffer == NULL && priv->buffer_queue->length) in try_write_next_buffer()
105 priv->buffer_queue = g_queue_new (); in soup_cache_input_stream_init()
152 g_queue_free_full (priv->buffer_queue, (GDestroyNotify) soup_buffer_free); in soup_cache_input_stream_finalize()
178 g_queue_push_head (priv->buffer_queue, subbuffer); in write_ready_cb()
192 SoupBuffer *buffer = g_queue_pop_head (priv->buffer_queue); in soup_cache_input_stream_write_next_buffer()
200 if (priv->buffer_queue->length > 10) in soup_cache_input_stream_write_next_buffer()
238 g_queue_push_tail (priv->buffer_queue, soup_buffer); in read_internal()
/third_party/gstreamer/gstplugins_base/ext/vorbis/
Dgstvorbisparse.c295 while (parse->buffer_queue->length) { in vorbis_parse_clear_queue()
298 buf = GST_BUFFER_CAST (g_queue_pop_head (parse->buffer_queue)); in vorbis_parse_clear_queue()
342 while (!g_queue_is_empty (parse->buffer_queue)) { in vorbis_parse_drain_queue_prematurely()
345 buf = GST_BUFFER_CAST (g_queue_pop_head (parse->buffer_queue)); in vorbis_parse_drain_queue_prematurely()
368 for (walk = parse->buffer_queue->head; walk; walk = walk->next) in vorbis_parse_drain_queue()
374 while (!g_queue_is_empty (parse->buffer_queue)) { in vorbis_parse_drain_queue()
377 buf = GST_BUFFER_CAST (g_queue_pop_head (parse->buffer_queue)); in vorbis_parse_drain_queue()
409 packet.packetno = parse->packetno + parse->buffer_queue->length; in vorbis_parse_queue_buffer()
424 g_queue_push_tail (parse->buffer_queue, buf); in vorbis_parse_queue_buffer()
691 parse->buffer_queue = g_queue_new (); in vorbis_parse_change_state()
[all …]
Dgstvorbisparse.h61 GQueue * buffer_queue; member
/third_party/gstreamer/gstplugins_base/ext/theora/
Dgsttheoraparse.c390 while (parse->buffer_queue->length) { in theora_parse_clear_queue()
393 buf = GST_BUFFER_CAST (g_queue_pop_head (parse->buffer_queue)); in theora_parse_clear_queue()
538 while (!g_queue_is_empty (parse->buffer_queue)) { in theora_parse_drain_queue_prematurely()
541 buf = GST_BUFFER_CAST (g_queue_pop_head (parse->buffer_queue)); in theora_parse_drain_queue_prematurely()
585 g_queue_get_length (parse->buffer_queue)); in theora_parse_drain_queue()
590 prev_frame = frame - g_queue_get_length (parse->buffer_queue); in theora_parse_drain_queue()
609 while (!g_queue_is_empty (parse->buffer_queue)) { in theora_parse_drain_queue()
615 buf = GST_BUFFER_CAST (g_queue_pop_head (parse->buffer_queue)); in theora_parse_drain_queue()
641 g_queue_push_tail (parse->buffer_queue, buf); in theora_parse_queue_buffer()
912 parse->buffer_queue = g_queue_new (); in theora_parse_change_state()
[all …]
Dgsttheoraparse.h63 GQueue * buffer_queue; member
/third_party/gstreamer/gstplugins_bad/sys/dvb/
Ddvbbasebin.h51 GstElement *buffer_queue; member
Ddvbbasebin.c492 dvbbasebin->buffer_queue = gst_element_factory_make ("queue", NULL); in dvb_base_bin_init()
495 g_object_set (dvbbasebin->buffer_queue, "max-size-buffers", 0, in dvb_base_bin_init()
499 dvbbasebin->buffer_queue, dvbbasebin->tsparse, NULL); in dvb_base_bin_init()
502 dvbbasebin->buffer_queue, dvbbasebin->tsparse, NULL); in dvb_base_bin_init()
561 gst_bin_remove (GST_BIN (dvbbasebin), dvbbasebin->buffer_queue); in dvb_base_bin_dispose()
/third_party/gstreamer/gstreamer/libs/gst/check/
Dgstharness.c179 GAsyncQueue *buffer_queue; member
225 g_async_queue_push (priv->buffer_queue, buffer); in gst_harness_chain()
695 priv->buffer_queue = g_async_queue_new_full ( in gst_harness_new_empty()
1156 g_async_queue_unref (priv->buffer_queue); in gst_harness_teardown()
1157 priv->buffer_queue = NULL; in gst_harness_teardown()
1687 GstBuffer *buf = (GstBuffer *) g_async_queue_timeout_pop (priv->buffer_queue, in gst_harness_pull()
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()
1821 return g_async_queue_length (priv->buffer_queue); in gst_harness_buffers_in_queue()
1864 g_async_queue_lock (priv->buffer_queue); in gst_harness_take_all_data_as_buffer()
[all …]