Lines Matching refs:memblockq
85 pa_memblockq *memblockq; member
122 pa_memblockq *memblockq; member
354 pa_memblockq_free(s->memblockq); in record_stream_free()
374 if (pa_memblockq_push_align(s->memblockq, chunk) < 0) { in record_stream_process_msg()
589 s->memblockq = pa_memblockq_new( in record_stream_new()
601 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr); in record_stream_new()
658 pa_memblockq_free(s->memblockq); in playback_stream_free()
1068 start_index = ssync ? pa_memblockq_get_read_index(ssync->memblockq) : 0; in playback_stream_new()
1074 s->memblockq = pa_memblockq_new( in playback_stream_new()
1087 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr); in playback_stream_new()
1089 *missing = (uint32_t) pa_memblockq_pop_missing(s->memblockq); in playback_stream_new()
1121 m = pa_memblockq_pop_missing(s->memblockq); in playback_stream_request_bytes()
1256 if (pa_memblockq_peek(r->memblockq, &chunk) >= 0) { in native_connection_send_memblock()
1264 pa_memblockq_drop(r->memblockq, schunk.length); in native_connection_send_memblock()
1284 if (pa_memblockq_is_readable(s->memblockq)) { in handle_seek()
1299 indexr = pa_memblockq_get_read_index(s->memblockq); in handle_seek()
1330 int64_t windex = pa_memblockq_get_write_index(s->memblockq); in sink_input_process_msg()
1337 …pa_memblockq_seek(s->memblockq, offset, PA_PTR_TO_UINT(userdata), PA_PTR_TO_UINT(userdata) == PA_S… in sink_input_process_msg()
1338 windex = PA_MIN(windex, pa_memblockq_get_write_index(s->memblockq)); in sink_input_process_msg()
1341 if (chunk && pa_memblockq_push_align(s->memblockq, chunk) < 0) { in sink_input_process_msg()
1345 pa_memblockq_seek(s->memblockq, (int64_t) chunk->length, PA_SEEK_RELATIVE, true); in sink_input_process_msg()
1387 windex = pa_memblockq_get_write_index(s->memblockq); in sink_input_process_msg()
1388 func(s->memblockq); in sink_input_process_msg()
1394 windex = pa_memblockq_get_write_index(ssync->memblockq); in sink_input_process_msg()
1395 func(ssync->memblockq); in sink_input_process_msg()
1401 windex = pa_memblockq_get_write_index(ssync->memblockq); in sink_input_process_msg()
1402 func(ssync->memblockq); in sink_input_process_msg()
1407 if (!pa_memblockq_is_readable(s->memblockq)) in sink_input_process_msg()
1420 s->read_index = pa_memblockq_get_read_index(s->memblockq); in sink_input_process_msg()
1421 s->write_index = pa_memblockq_get_write_index(s->memblockq); in sink_input_process_msg()
1432 windex = pa_memblockq_get_write_index(s->memblockq); in sink_input_process_msg()
1440 pa_memblockq_prebuf_force(s->memblockq); in sink_input_process_msg()
1451 *r = pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &i->sample_spec); in sink_input_process_msg()
1459 pa_memblockq_apply_attr(s->memblockq, &s->buffer_attr); in sink_input_process_msg()
1460 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr); in sink_input_process_msg()
1471 if (pa_memblockq_is_readable(s->memblockq)) in handle_input_underrun()
1485 …), PLAYBACK_STREAM_MESSAGE_UNDERFLOW, NULL, pa_memblockq_get_read_index(s->memblockq), NULL, NULL); in handle_input_underrun()
1513 …list_gets(i->proplist, PA_PROP_MEDIA_NAME), (unsigned long) pa_memblockq_get_length(s->memblockq)); in sink_input_pop_cb()
1521 if (pa_memblockq_peek(s->memblockq, chunk) < 0) in sink_input_pop_cb()
1529 pa_memblockq_drop(s->memblockq, chunk->length); in sink_input_pop_cb()
1547 pa_memblockq_rewind(s->memblockq, nbytes); in sink_input_process_rewind_cb()
1558 pa_memblockq_set_maxrewind(s->memblockq, nbytes); in sink_input_update_max_rewind_cb()
1570 old_tlength = pa_memblockq_get_tlength(s->memblockq); in sink_input_update_max_request_cb()
1571 new_tlength = nbytes+2*pa_memblockq_get_minreq(s->memblockq); in sink_input_update_max_request_cb()
1575 pa_memblockq_set_tlength(s->memblockq, new_tlength); in sink_input_update_max_request_cb()
1576 new_tlength = pa_memblockq_get_tlength(s->memblockq); in sink_input_update_max_request_cb()
1582 … PLAYBACK_STREAM_MESSAGE_UPDATE_TLENGTH, NULL, pa_memblockq_get_tlength(s->memblockq), NULL, NULL); in sink_input_update_max_request_cb()
1661 pa_memblockq_apply_attr(s->memblockq, &s->buffer_attr); in sink_input_moving_cb()
1662 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr); in sink_input_moving_cb()
1742 return pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &o->sample_spec); in source_output_get_latency_cb()
1807 pa_memblockq_set_maxlength(s->memblockq, s->buffer_attr.maxlength); in source_output_moving_cb()
1808 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr); in source_output_moving_cb()
2952 pa_tagstruct_puts64(reply, pa_memblockq_get_write_index(s->memblockq)); in command_get_record_latency()
2953 pa_tagstruct_puts64(reply, pa_memblockq_get_read_index(s->memblockq)); in command_get_record_latency()
4035 pa_memblockq_prebuf_force(s->memblockq); in command_cork_record_stream()
4057 pa_memblockq_flush_read(s->memblockq); in command_flush_record_stream()
4142 pa_memblockq_set_maxlength(s->memblockq, s->buffer_attr.maxlength); in command_set_stream_buffer_attr()
4143 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr); in command_set_stream_buffer_attr()