Lines Matching refs:memblockq
194 pa_memblockq_free(s->memblockq);
214 if (pa_memblockq_push_align(s->memblockq, chunk) < 0) {
428 memblockq_name = pa_sprintf_malloc("native protocol record stream memblockq [%u]", s->source_output->index);
429 s->memblockq = pa_memblockq_new(
441 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr);
498 pa_memblockq_free(s->memblockq);
647 * ->thread_info data, such as the memblockq! */
922 start_index = ssync ? pa_memblockq_get_read_index(ssync->memblockq) : 0;
927 memblockq_name = pa_sprintf_malloc("native protocol playback stream memblockq [%u]", s->sink_input->index);
928 s->memblockq = pa_memblockq_new(
941 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr);
943 *missing = (uint32_t) pa_memblockq_pop_missing(s->memblockq);
1084 if (pa_memblockq_peek(r->memblockq, &chunk) >= 0) {
1092 pa_memblockq_drop(r->memblockq, schunk.length);
1106 /* pa_log("handle_seek: %llu -- %i", (unsigned long long) s->sink_input->thread_info.underrun_for, pa_memblockq_is_readable(s->memblockq)); */
1110 /* pa_log("%lu vs. %lu", (unsigned long) pa_memblockq_get_length(s->memblockq), (unsigned long) pa_memblockq_get_prebuf(s->memblockq)); */
1112 if (pa_memblockq_is_readable(s->memblockq)) {
1127 indexr = pa_memblockq_get_read_index(s->memblockq);
1158 int64_t windex = pa_memblockq_get_write_index(s->memblockq);
1165 pa_memblockq_seek(s->memblockq, offset, PA_PTR_TO_UINT(userdata), PA_PTR_TO_UINT(userdata) == PA_SEEK_RELATIVE);
1166 windex = PA_MIN(windex, pa_memblockq_get_write_index(s->memblockq));
1169 if (chunk && pa_memblockq_push_align(s->memblockq, chunk) < 0) {
1173 pa_memblockq_seek(s->memblockq, (int64_t) chunk->length, PA_SEEK_RELATIVE, true);
1215 windex = pa_memblockq_get_write_index(s->memblockq);
1216 func(s->memblockq);
1222 windex = pa_memblockq_get_write_index(ssync->memblockq);
1223 func(ssync->memblockq);
1229 windex = pa_memblockq_get_write_index(ssync->memblockq);
1230 func(ssync->memblockq);
1235 if (!pa_memblockq_is_readable(s->memblockq))
1248 s->read_index = pa_memblockq_get_read_index(s->memblockq);
1249 s->write_index = pa_memblockq_get_write_index(s->memblockq);
1262 windex = pa_memblockq_get_write_index(s->memblockq);
1270 pa_memblockq_prebuf_force(s->memblockq);
1281 *r = pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &i->sample_spec);
1289 pa_memblockq_apply_attr(s->memblockq, &s->buffer_attr);
1290 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr);
1301 if (pa_memblockq_is_readable(s->memblockq))
1315 pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(s), PLAYBACK_STREAM_MESSAGE_UNDERFLOW, NULL, pa_memblockq_get_read_index(s->memblockq), NULL, NULL);
1336 if (pa_memblockq_is_readable(s->memblockq))
1347 NULL, pa_memblockq_get_read_index(s->memblockq), NULL, NULL);
1372 pa_log("%s, pop(): %lu", pa_proplist_gets(i->proplist, PA_PROP_MEDIA_NAME), (unsigned long) pa_memblockq_get_length(s->memblockq));
1380 if (pa_memblockq_peek(s->memblockq, chunk) < 0)
1388 pa_memblockq_drop(s->memblockq, chunk->length);
1406 pa_memblockq_rewind(s->memblockq, nbytes);
1417 pa_memblockq_set_maxrewind(s->memblockq, nbytes);
1429 old_tlength = pa_memblockq_get_tlength(s->memblockq);
1430 new_tlength = nbytes+2*pa_memblockq_get_minreq(s->memblockq);
1435 pa_memblockq_set_tlength(s->memblockq, new_tlength);
1436 new_tlength = pa_memblockq_get_tlength(s->memblockq);
1442 pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(s), PLAYBACK_STREAM_MESSAGE_UPDATE_TLENGTH, NULL, pa_memblockq_get_tlength(s->memblockq), NULL, NULL);
1521 pa_memblockq_apply_attr(s->memblockq, &s->buffer_attr);
1522 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr);
1602 /*pa_log("get_latency: %u", pa_memblockq_get_length(s->memblockq));*/
1604 return pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &o->sample_spec);
1669 pa_memblockq_set_maxlength(s->memblockq, s->buffer_attr.maxlength);
1670 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr);
2823 pa_tagstruct_puts64(reply, pa_memblockq_get_write_index(s->memblockq));
2824 pa_tagstruct_puts64(reply, pa_memblockq_get_read_index(s->memblockq));
3906 pa_memblockq_prebuf_force(s->memblockq);
3928 pa_memblockq_flush_read(s->memblockq);
4013 pa_memblockq_set_maxlength(s->memblockq, s->buffer_attr.maxlength);
4014 pa_memblockq_get_attr(s->memblockq, &s->buffer_attr);