Searched refs:bufqueue (Results 1 – 10 of 10) sorted by relevance
| /third_party/gstreamer/gstreamer/libs/gst/base/ |
| D | gstadapter.c | 145 GstQueueArray *bufqueue; member
212 adapter->bufqueue = gst_queue_array_new (10); in gst_adapter_init()
232 gst_queue_array_free (adapter->bufqueue); in gst_adapter_finalize()
265 while ((obj = gst_queue_array_pop_head (adapter->bufqueue))) in gst_adapter_clear()
337 buf = gst_queue_array_peek_nth (adapter->bufqueue, idx++); in copy_into_unchecked()
341 buf = gst_queue_array_peek_nth (adapter->bufqueue, idx++); in copy_into_unchecked()
356 buf = gst_queue_array_peek_nth (adapter->bufqueue, idx++); in copy_into_unchecked()
389 if (gst_queue_array_is_empty (adapter->bufqueue)) { in gst_adapter_push()
392 gst_queue_array_push_tail (adapter->bufqueue, buf); in gst_adapter_push()
398 gst_queue_array_push_tail (adapter->bufqueue, buf); in gst_adapter_push()
[all …]
|
| /third_party/gstreamer/gstplugins_base/gst/tcp/ |
| D | gstmultihandlesink.c | 425 this->bufqueue = g_array_new (FALSE, TRUE, sizeof (GstBuffer *)); in gst_multi_handle_sink_init()
453 g_array_free (this->bufqueue, TRUE); in gst_multi_handle_sink_finalize()
1093 len = sink->bufqueue->len; in find_syncframe()
1102 buf = g_array_index (sink->bufqueue, GstBuffer *, i); in find_syncframe()
1131 len = sink->bufqueue->len; in get_buffers_max()
1134 buf = g_array_index (sink->bufqueue, GstBuffer *, i); in get_buffers_max()
1154 len = sink->bufqueue->len; in get_buffers_max()
1157 buf = g_array_index (sink->bufqueue, GstBuffer *, i); in get_buffers_max()
1192 len = sink->bufqueue->len; in find_limits()
1239 buf = g_array_index (sink->bufqueue, GstBuffer *, i); in find_limits()
[all …]
|
| D | gstmultihandlesink.h | 210 GArray *bufqueue; /* global queue of buffers */ member
|
| D | gstmultifdsink.c | 735 buf = g_array_index (mhsink->bufqueue, GstBuffer *, mhclient->bufpos); in gst_multi_fd_sink_handle_client_write()
|
| D | gstmultisocketsink.c | 882 buf = g_array_index (mhsink->bufqueue, GstBuffer *, mhclient->bufpos); in gst_multi_socket_sink_handle_client_write()
|
| /third_party/ffmpeg/libavcodec/ |
| D | opusenc.c | 43 struct FFBufQueue bufqueue; member
123 cur = ff_bufqueue_get(&s->bufqueue); in celt_frame_setup_input()
136 cur = ff_bufqueue_get(&s->bufqueue); in celt_frame_setup_input()
138 cur = ff_bufqueue_peek(&s->bufqueue, 0); in celt_frame_setup_input()
544 ff_bufqueue_add(avctx, &s->bufqueue, av_frame_clone(frame)); in opus_encode_frame()
559 … int pad_empty = s->packet.frames*(frame_size/s->avctx->frame_size) - s->bufqueue.available + 1; in opus_encode_frame()
568 ff_bufqueue_add(avctx, &s->bufqueue, empty); in opus_encode_frame()
616 ff_bufqueue_discard_all(&s->bufqueue); in opus_encode_end()
674 ff_bufqueue_add(avctx, &s->bufqueue, spawn_empty_frame(s)); in opus_encode_init()
675 if (!ff_bufqueue_peek(&s->bufqueue, 0)) in opus_encode_init()
[all …]
|
| D | opusenc_psy.h | 59 struct FFBufQueue *bufqueue; member
102 struct FFBufQueue *bufqueue, OpusEncOptions *options);
|
| D | opusenc_psy.c | 90 AVFrame *cur = ff_bufqueue_peek(s->bufqueue, index - i); in step_collect_psy_metrics()
95 AVFrame *cur = ff_bufqueue_peek(s->bufqueue, index + i); in step_collect_psy_metrics()
517 struct FFBufQueue *bufqueue, OpusEncOptions *options) in ff_opus_psy_init() argument
525 s->bufqueue = bufqueue; in ff_opus_psy_init()
|
| D | vorbisenc.c | 119 struct FFBufQueue bufqueue; member
1068 cur = ff_bufqueue_get(&venc->bufqueue); in move_audio()
1102 ff_bufqueue_add(avctx, &venc->bufqueue, clone); in vorbis_encode_frame()
1107 need_more = venc->bufqueue.available * avctx->frame_size < frame_size; in vorbis_encode_frame()
1114 if (venc->bufqueue.available * avctx->frame_size < frame_size) { in vorbis_encode_frame()
1115 int frames_needed = (frame_size/avctx->frame_size) - venc->bufqueue.available; in vorbis_encode_frame()
1123 ff_bufqueue_add(avctx, &venc->bufqueue, empty); in vorbis_encode_frame()
1260 ff_bufqueue_discard_all(&venc->bufqueue); in vorbis_encode_close()
|
| /third_party/gstreamer/gstplugins_base/ |
| D | ChangeLog | 150378 gst/tcp/gstmultifdsink.c: clean up the bufqueue when shutting down
150381 clean up the bufqueue when shutting down
|