Lines Matching defs:memblockq
42 #include <pulsecore/memblockq.h>
90 pa_memblockq *memblockq;
139 *((pa_usec_t*) data) = pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &s->sink_input->sample_spec);
155 if (pa_memblockq_peek(s->memblockq, chunk) < 0)
158 pa_memblockq_drop(s->memblockq, chunk->length);
170 pa_memblockq_rewind(s->memblockq, nbytes);
180 pa_memblockq_set_maxrewind(s->memblockq, nbytes);
199 pa_memblockq_flush_read(s->memblockq);
249 pa_memblockq_seek(s->memblockq, delta * (int64_t) pa_rtp_context_get_frame_size(s->rtp_context), PA_SEEK_RELATIVE,
260 if (pa_memblockq_push(s->memblockq, &chunk) < 0) {
262 pa_memblockq_seek(s->memblockq, (int64_t) chunk.length, PA_SEEK_RELATIVE, true);
265 /* pa_log("blocks in q: %u", pa_memblockq_get_nblocks(s->memblockq)); */
282 wi = pa_bytes_to_usec((uint64_t) pa_memblockq_get_write_index(s->memblockq), &s->sink_input->sample_spec);
283 ri = pa_bytes_to_usec((uint64_t) pa_memblockq_get_read_index(s->memblockq), &s->sink_input->sample_spec);
366 if (pa_memblockq_is_readable(s->memblockq) &&
559 s->memblockq = pa_memblockq_new(
560 "module-rtp-recv memblockq",
606 pa_memblockq_free(s->memblockq);