Lines Matching refs:memblockq
91 pa_memblockq *memblockq; member
128 pa_memblockq *memblockq; member
362 pa_memblockq_free(s->memblockq); in record_stream_free()
382 if (pa_memblockq_push_align(s->memblockq, chunk) < 0) { in record_stream_process_msg()
597 s->memblockq = pa_memblockq_new( in record_stream_new()
609 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr); in record_stream_new()
666 pa_memblockq_free(s->memblockq); in playback_stream_free()
1090 start_index = ssync ? pa_memblockq_get_read_index(ssync->memblockq) : 0; in playback_stream_new()
1096 s->memblockq = pa_memblockq_new( in playback_stream_new()
1109 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr); in playback_stream_new()
1111 *missing = (uint32_t) pa_memblockq_pop_missing(s->memblockq); in playback_stream_new()
1143 m = pa_memblockq_pop_missing(s->memblockq); in playback_stream_request_bytes()
1278 if (pa_memblockq_peek(r->memblockq, &chunk) >= 0) { in native_connection_send_memblock()
1286 pa_memblockq_drop(r->memblockq, schunk.length); in native_connection_send_memblock()
1306 if (pa_memblockq_is_readable(s->memblockq)) { in handle_seek()
1321 indexr = pa_memblockq_get_read_index(s->memblockq); in handle_seek()
1352 int64_t windex = pa_memblockq_get_write_index(s->memblockq); in sink_input_process_msg()
1359 …pa_memblockq_seek(s->memblockq, offset, PA_PTR_TO_UINT(userdata), PA_PTR_TO_UINT(userdata) == PA_S… in sink_input_process_msg()
1360 windex = PA_MIN(windex, pa_memblockq_get_write_index(s->memblockq)); in sink_input_process_msg()
1363 if (chunk && pa_memblockq_push_align(s->memblockq, chunk) < 0) { in sink_input_process_msg()
1367 pa_memblockq_seek(s->memblockq, (int64_t) chunk->length, PA_SEEK_RELATIVE, true); in sink_input_process_msg()
1409 windex = pa_memblockq_get_write_index(s->memblockq); in sink_input_process_msg()
1410 func(s->memblockq); in sink_input_process_msg()
1416 windex = pa_memblockq_get_write_index(ssync->memblockq); in sink_input_process_msg()
1417 func(ssync->memblockq); in sink_input_process_msg()
1423 windex = pa_memblockq_get_write_index(ssync->memblockq); in sink_input_process_msg()
1424 func(ssync->memblockq); in sink_input_process_msg()
1429 if (!pa_memblockq_is_readable(s->memblockq)) in sink_input_process_msg()
1442 s->read_index = pa_memblockq_get_read_index(s->memblockq); in sink_input_process_msg()
1443 s->write_index = pa_memblockq_get_write_index(s->memblockq); in sink_input_process_msg()
1456 windex = pa_memblockq_get_write_index(s->memblockq); in sink_input_process_msg()
1464 pa_memblockq_prebuf_force(s->memblockq); in sink_input_process_msg()
1475 *r = pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &i->sample_spec); in sink_input_process_msg()
1483 pa_memblockq_apply_attr(s->memblockq, &s->buffer_attr); in sink_input_process_msg()
1484 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr); in sink_input_process_msg()
1495 if (pa_memblockq_is_readable(s->memblockq)) in handle_input_underrun()
1509 …), PLAYBACK_STREAM_MESSAGE_UNDERFLOW, NULL, pa_memblockq_get_read_index(s->memblockq), NULL, NULL); in handle_input_underrun()
1530 if (pa_memblockq_is_readable(s->memblockq)) in handle_input_underrun_ohos()
1541 NULL, pa_memblockq_get_read_index(s->memblockq), NULL, NULL); in handle_input_underrun_ohos()
1566 …list_gets(i->proplist, PA_PROP_MEDIA_NAME), (unsigned long) pa_memblockq_get_length(s->memblockq)); in sink_input_pop_cb()
1574 if (pa_memblockq_peek(s->memblockq, chunk) < 0) in sink_input_pop_cb()
1582 pa_memblockq_drop(s->memblockq, chunk->length); in sink_input_pop_cb()
1600 pa_memblockq_rewind(s->memblockq, nbytes); in sink_input_process_rewind_cb()
1611 pa_memblockq_set_maxrewind(s->memblockq, nbytes); in sink_input_update_max_rewind_cb()
1623 old_tlength = pa_memblockq_get_tlength(s->memblockq); in sink_input_update_max_request_cb()
1624 new_tlength = nbytes+2*pa_memblockq_get_minreq(s->memblockq); in sink_input_update_max_request_cb()
1629 pa_memblockq_set_tlength(s->memblockq, new_tlength); in sink_input_update_max_request_cb()
1630 new_tlength = pa_memblockq_get_tlength(s->memblockq); in sink_input_update_max_request_cb()
1636 … PLAYBACK_STREAM_MESSAGE_UPDATE_TLENGTH, NULL, pa_memblockq_get_tlength(s->memblockq), NULL, NULL); in sink_input_update_max_request_cb()
1715 pa_memblockq_apply_attr(s->memblockq, &s->buffer_attr); in sink_input_moving_cb()
1716 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr); in sink_input_moving_cb()
1798 return pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &o->sample_spec); in source_output_get_latency_cb()
1863 pa_memblockq_set_maxlength(s->memblockq, s->buffer_attr.maxlength); in source_output_moving_cb()
1864 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr); in source_output_moving_cb()
3017 pa_tagstruct_puts64(reply, pa_memblockq_get_write_index(s->memblockq)); in command_get_record_latency()
3018 pa_tagstruct_puts64(reply, pa_memblockq_get_read_index(s->memblockq)); in command_get_record_latency()
4100 pa_memblockq_prebuf_force(s->memblockq); in command_cork_record_stream()
4122 pa_memblockq_flush_read(s->memblockq); in command_flush_record_stream()
4207 pa_memblockq_set_maxlength(s->memblockq, s->buffer_attr.maxlength); in command_set_stream_buffer_attr()
4208 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr); in command_set_stream_buffer_attr()