| /third_party/pulseaudio/src/pulsecore/ |
| H A D | play-memblockq.c | 32 #include "play-memblockq.h"
38 pa_memblockq *memblockq; member
65 if (u->memblockq) in memblockq_stream_free()
66 pa_memblockq_free(u->memblockq); in memblockq_stream_free()
117 if (!u->memblockq) in sink_input_pop_cb()
120 if (pa_memblockq_peek(u->memblockq, chunk) < 0) { in sink_input_pop_cb()
124 pa_memblockq_free(u->memblockq); in sink_input_pop_cb()
125 u->memblockq = NULL; in sink_input_pop_cb()
133 /* If there's no memblock, there's going to be data in the memblockq after in sink_input_pop_cb()
136 * gap will occur if the memblockq i in sink_input_pop_cb()
[all...] |
| H A D | sound-file-stream.c | 55 /* We need this memblockq here to easily fulfill rewind requests
57 pa_memblockq *memblockq; member
87 if (u->memblockq) in file_stream_free()
88 pa_memblockq_free(u->memblockq); in file_stream_free()
145 if (!u->memblockq) in sink_input_pop_cb()
154 if (pa_memblockq_peek(u->memblockq, chunk) >= 0) { in sink_input_pop_cb()
156 pa_memblockq_drop(u->memblockq, chunk->length); in sink_input_pop_cb()
188 pa_memblockq_push_align(u->memblockq, &tchunk); in sink_input_pop_cb()
193 pa_memblockq_free(u->memblockq); in sink_input_pop_cb()
194 u->memblockq in sink_input_pop_cb()
[all...] |
| H A D | memblockq.h | 36 /* A memblockq is a queue of pa_memchunks (yep, the name is not
38 * audio software. In contrast to a ring buffer this memblockq data
178 * silence memchunk for this memblockq if you use this call. */
197 /* Directly moves the data from the source memblockq into bq */
237 void pa_memblockq_set_maxlength(pa_memblockq *memblockq, size_t maxlength); /* might modify tlength, prebuf, minreq too */
238 void pa_memblockq_set_tlength(pa_memblockq *memblockq, size_t tlength); /* might modify minreq, too */
239 void pa_memblockq_set_minreq(pa_memblockq *memblockq, size_t minreq); /* might modify prebuf, too */
240 void pa_memblockq_set_prebuf(pa_memblockq *memblockq, size_t prebuf);
241 void pa_memblockq_set_maxrewind(pa_memblockq *memblockq, size_t maxrewind); /* Set the maximum history size */
242 void pa_memblockq_set_silence(pa_memblockq *memblockq, pa_memchun
[all...] |
| H A D | protocol-native.h | 73 pa_memblockq *memblockq; member
110 pa_memblockq *memblockq; member
237 m = pa_memblockq_pop_missing(s->memblockq); in playback_stream_request_bytes()
243 /* pa_memblockq_get_tlength(s->memblockq), */ in playback_stream_request_bytes()
244 /* pa_memblockq_get_minreq(s->memblockq), */ in playback_stream_request_bytes()
245 /* pa_memblockq_get_length(s->memblockq), */ in playback_stream_request_bytes()
246 /* (long long) pa_memblockq_get_tlength(s->memblockq) - (long long) pa_memblockq_get_length(s->memblockq)); */ in playback_stream_request_bytes()
|
| H A D | protocol-native.c | 194 pa_memblockq_free(s->memblockq); in record_stream_free()
214 if (pa_memblockq_push_align(s->memblockq, chunk) < 0) { in record_stream_process_msg()
428 memblockq_name = pa_sprintf_malloc("native protocol record stream memblockq [%u]", s->source_output->index); in record_stream_new()
429 s->memblockq = pa_memblockq_new( in record_stream_new()
441 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr); in record_stream_new()
498 pa_memblockq_free(s->memblockq); in playback_stream_free()
647 * ->thread_info data, such as the memblockq! */ in fix_playback_buffer_attr()
922 start_index = ssync ? pa_memblockq_get_read_index(ssync->memblockq) : 0; in playback_stream_new()
927 memblockq_name = pa_sprintf_malloc("native protocol playback stream memblockq [%u]", s->sink_input->index); in playback_stream_new()
928 s->memblockq in playback_stream_new()
[all...] |
| H A D | play-memblockq.h | 24 #include <pulsecore/memblockq.h>
|
| H A D | play-memchunk.c | 28 #include <pulsecore/play-memblockq.h>
|
| H A D | sink-input.h | 29 #include <pulsecore/memblockq.h>
|
| H A D | source-output.h | 28 #include <pulsecore/memblockq.h>
216 /* We maintain a delay memblockq here for source outputs that
|
| H A D | sink-input.c | 39 #include <pulsecore/play-memblockq.h>
656 memblockq_name = pa_sprintf_malloc("sink input history memblockq [%u]", i->index); in pa_sink_input_new()
1155 /* Keep memblockq's in sync. Using pa_resampler_request() in pa_sink_input_drop()
1208 pa_log_debug("Have to rewind %lu bytes on render memblockq.", (unsigned long) nbytes); in pa_sink_input_process_rewind()
2071 /* Restores the render memblockq from the history memblockq during a move.
2087 /* Flush the render memblockq and reset the resampler */ in restore_render_memblockq()
2096 /* If something is left playing on the origin sink, add silence to the render memblockq */ in restore_render_memblockq()
2116 /* Now push all the data in the history queue into the render memblockq */ in restore_render_memblockq()
2127 pa_log_warn("Could not restore memblockq durin in restore_render_memblockq()
[all...] |
| H A D | sink.c | 48 #include <pulsecore/play-memblockq.h>
2764 * the render memblockq in finish_move(). */ in pa_sink_process_msg()
2839 * the data in the render memblockq will get lost */ in pa_sink_process_msg()
|
| /third_party/pulseaudio/src/modules/rtp/ |
| H A D | module-rtp-recv.c | 42 #include <pulsecore/memblockq.h>
90 pa_memblockq *memblockq; member
139 *((pa_usec_t*) data) = pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &s->sink_input->sample_spec); in sink_input_process_msg()
155 if (pa_memblockq_peek(s->memblockq, chunk) < 0) in sink_input_pop_cb()
158 pa_memblockq_drop(s->memblockq, chunk->length); in sink_input_pop_cb()
170 pa_memblockq_rewind(s->memblockq, nbytes); in sink_input_process_rewind_cb()
180 pa_memblockq_set_maxrewind(s->memblockq, nbytes); in sink_input_update_max_rewind_cb()
199 pa_memblockq_flush_read(s->memblockq); in sink_input_suspend_within_thread()
249 pa_memblockq_seek(s->memblockq, delta * (int64_t) pa_rtp_context_get_frame_size(s->rtp_context), PA_SEEK_RELATIVE, in rtpoll_work_cb()
260 if (pa_memblockq_push(s->memblockq, in rtpoll_work_cb()
[all...] |
| H A D | module-rtp-send.c | 39 #include <pulsecore/memblockq.h>
110 pa_memblockq *memblockq; member
127 *((pa_usec_t*) data) = pa_bytes_to_usec(pa_memblockq_get_length(u->memblockq), &u->source_output->sample_spec); in source_output_process_msg()
143 if (pa_memblockq_push(u->memblockq, chunk) < 0) { in source_output_push_cb()
144 pa_log_warn("Failed to push chunk into memblockq."); in source_output_push_cb()
148 pa_rtp_send(u->rtp_context, u->memblockq); in source_output_push_cb()
470 u->memblockq = pa_memblockq_new( in pa__init()
471 "module-rtp-send memblockq", in pa__init()
556 if (u->memblockq) in pa__done()
557 pa_memblockq_free(u->memblockq); in pa__done()
[all...] |
| H A D | sap.h | 26 #include <pulsecore/memblockq.h>
|
| H A D | rtp.h | 26 #include <pulsecore/memblockq.h>
35 /* If the memblockq doesn't have a silence memchunk set, then the caller must
|
| /third_party/pulseaudio/src/modules/ |
| H A D | module-virtual-sink.c | 65 pa_memblockq *memblockq; member
163 pa_memblockq_get_length(u->memblockq), true, false, false); in sink_request_rewind_cb()
234 while (pa_memblockq_peek(u->memblockq, &tchunk) < 0) { in sink_input_pop_cb()
238 pa_memblockq_push(u->memblockq, &nchunk); in sink_input_pop_cb()
256 pa_memblockq_drop(u->memblockq, chunk->length); in sink_input_pop_cb()
302 max_rewrite = nbytes + pa_memblockq_get_length(u->memblockq); in sink_input_process_rewind_cb()
307 pa_memblockq_seek(u->memblockq, - (int64_t) amount, PA_SEEK_RELATIVE, true); in sink_input_process_rewind_cb()
314 pa_memblockq_rewind(u->memblockq, nbytes); in sink_input_process_rewind_cb()
326 pa_memblockq_set_maxrewind(u->memblockq, nbytes); in sink_input_update_max_rewind_cb()
617 u->memblockq in pa__init()
[all...] |
| H A D | module-loopback.c | 86 pa_memblockq *memblockq; member
705 * Sets the memblockq to the configured latency corrected by latency_offset_usec */
714 * hold more than final_latency in the memblockq */ in memblockq_adjust()
724 current_memblockq_length = pa_memblockq_get_length(u->memblockq); in memblockq_adjust()
730 pa_memblockq_drop(u->memblockq, buffer_correction); in memblockq_adjust()
736 pa_memblockq_seek(u->memblockq, (int64_t)buffer_correction, PA_SEEK_RELATIVE, true); in memblockq_adjust()
783 /* Add content of delay memblockq to the source latency */ in source_output_process_msg_cb()
1033 if (pa_memblockq_peek(u->memblockq, chunk) < 0) { in sink_input_pop_cb()
1039 pa_memblockq_drop(u->memblockq, chunk->length); in sink_input_pop_cb()
1041 /* Adjust the memblockq t in sink_input_pop_cb()
[all...] |
| H A D | module-combine-sink.c | 37 #include <pulsecore/memblockq.h>
123 pa_memblockq *memblockq; member
305 * memblockq at the time of the sink snapshot. */ in adjust_rates()
505 while (!pa_memblockq_is_readable(o->memblockq)) { in render_memblock()
524 pa_memblockq_push_align(o->memblockq, &chunk); in render_memblock()
542 if (pa_memblockq_is_readable(o->memblockq)) in request_memblock()
562 /* pa_memblockq_get_nblocks(o->memblockq), */ in sink_input_pop_cb()
564 /* pa_memblockq_get_maxrewind(o->memblockq), */ in sink_input_pop_cb()
567 if (pa_memblockq_peek(o->memblockq, chunk) < 0) in sink_input_pop_cb()
570 pa_memblockq_drop(o->memblockq, chun in sink_input_pop_cb()
[all...] |
| H A D | module-virtual-source.c | 72 pa_memblockq *memblockq; member
292 /* move the read pointer for sink memblockq */ in source_output_push_cb()
540 u->memblockq = pa_memblockq_new("module-virtual-source memblockq", 0, MEMBLOCKQ_MAXLENGTH, 0, &ss, 1, 1, 0, NULL); in pa__init()
541 if (!u->memblockq) { in pa__init()
542 pa_log("Failed to create source memblockq."); in pa__init()
663 pa_log("Failed to create sink memblockq."); in pa__init()
748 if (u->memblockq) in pa__done()
749 pa_memblockq_free(u->memblockq); in pa__done()
|
| H A D | module-ladspa-sink.c | 94 pa_memblockq *memblockq; member
431 pa_memblockq_get_length(u->memblockq), true, false, false); in sink_request_rewind_cb()
483 while (pa_memblockq_peek(u->memblockq, &tchunk) < 0) { in sink_input_pop_cb()
487 pa_memblockq_push(u->memblockq, &nchunk); in sink_input_pop_cb()
503 pa_memblockq_drop(u->memblockq, chunk->length); in sink_input_pop_cb()
539 max_rewrite = nbytes + pa_memblockq_get_length(u->memblockq); in sink_input_process_rewind_cb()
546 pa_memblockq_seek(u->memblockq, - (int64_t) amount, PA_SEEK_RELATIVE, true); in sink_input_process_rewind_cb()
561 pa_memblockq_rewind(u->memblockq, nbytes); in sink_input_process_rewind_cb()
573 pa_memblockq_set_maxrewind(u->memblockq, nbytes); in sink_input_update_max_rewind_cb()
1374 u->memblockq in pa__init()
[all...] |
| /third_party/pulseaudio/src/pulsecore/filter/ |
| H A D | lfe-filter.h | 28 #include <pulsecore/memblockq.h>
|
| /third_party/pulseaudio/src/pulse/ |
| H A D | internal.h | 40 #include <pulsecore/memblockq.h>
|
| /third_party/pulseaudio/src/tests/ |
| H A D | memblockq-test.c | 28 #include <pulsecore/memblockq.h>
205 bq = pa_memblockq_new("test memblockq", idx, maxlength, tlength, &ss, prebuf, minreq, maxrewind, &silence); in START_TEST()
253 bq = pa_memblockq_new("test memblockq", 0, 200, 10, &ss, 4, 4, 40, &silence); in START_TEST()
358 bq = pa_memblockq_new("test memblockq", idx, maxlength, tlength, &ss, prebuf, minreq, maxrewind, &silence); in START_TEST()
421 bq = pa_memblockq_new("test memblockq", idx, maxlength, tlength, &ss, prebuf, minreq, maxrewind, &silence); in START_TEST()
424 /* The following equation regarding the internal variables of a memblockq in START_TEST()
429 * "length" is the current memblockq length (write index minus read index) in START_TEST()
572 bq = pa_memblockq_new("test memblockq", 0, 4096, 2048, &ss, 0, 512, 512, NULL); in START_TEST()
646 tc = tcase_create("memblockq"); in main()
|
| H A D | resampler-rewind-test.c | 39 #include <pulsecore/memblockq.h>
|