Lines Matching refs:memblockq
90 pa_memblockq *memblockq; member
139 …*((pa_usec_t*) data) = pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &s->sink_input->sam… 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), P… in rtpoll_work_cb()
260 if (pa_memblockq_push(s->memblockq, &chunk) < 0) { in rtpoll_work_cb()
262 pa_memblockq_seek(s->memblockq, (int64_t) chunk.length, PA_SEEK_RELATIVE, true); in rtpoll_work_cb()
282 …wi = pa_bytes_to_usec((uint64_t) pa_memblockq_get_write_index(s->memblockq), &s->sink_input->sampl… in rtpoll_work_cb()
283 …ri = pa_bytes_to_usec((uint64_t) pa_memblockq_get_read_index(s->memblockq), &s->sink_input->sample… in rtpoll_work_cb()
365 if (pa_memblockq_is_readable(s->memblockq) && in rtpoll_work_cb()
558 s->memblockq = pa_memblockq_new( in session_new()
605 pa_memblockq_free(s->memblockq); in session_free()