| /third_party/pulseaudio/src/modules/ |
| H A D | module-virtual-sink.c | 106 pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_input->sink->sample_spec); in sink_process_msg_cb()
163 pa_memblockq_get_length(u->memblockq), true, false, false); in sink_request_rewind_cb()
282 pa_bytes_to_usec(pa_memblockq_get_length(i->thread_info.render_memblockq), &i->sink->sample_spec); in sink_input_pop_cb()
302 max_rewrite = nbytes + pa_memblockq_get_length(u->memblockq); in sink_input_process_rewind_cb()
|
| H A D | module-virtual-surround-sink.c | 281 pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_input->sink->sample_spec); in sink_process_msg_cb()
336 nbytes_sink = s->thread_info.rewind_nbytes + pa_memblockq_get_length(u->memblockq_sink); in sink_request_rewind_cb()
393 if ((l = pa_memblockq_get_length(bq)) >= tlength) in memblockq_missing()
515 max_rewrite = nbytes_sink + pa_memblockq_get_length(u->memblockq_sink); in sink_input_process_rewind_cb()
|
| H A D | module-loopback.c | 724 current_memblockq_length = pa_memblockq_get_length(u->memblockq); in memblockq_adjust()
780 length = pa_memblockq_get_length(u->source_output->thread_info.delay_memblockq); in source_output_process_msg_cb()
1071 *r = pa_bytes_to_usec(pa_memblockq_get_length(u->memblockq), &u->sink_input->sample_spec); in sink_input_process_msg_cb()
1169 length = pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq); in sink_input_process_msg_cb()
1172 u->latency_snapshot.loopback_memblockq_length = pa_memblockq_get_length(u->memblockq); in sink_input_process_msg_cb()
|
| H A D | module-equalizer-sink.c | 263 pa_bytes_to_usec(pa_memblockq_get_length(u->output_q) + in sink_process_msg_cb()
264 pa_memblockq_get_length(u->input_q), &u->sink_input->sink->sample_spec) + in sink_process_msg_cb()
265 pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_input->sink->sample_spec); in sink_process_msg_cb()
322 pa_sink_input_request_rewind(u->sink_input, s->thread_info.rewind_nbytes+pa_memblockq_get_length(u->input_q), true, false, false); in sink_request_rewind_cb()
631 if (pa_memblockq_get_length(u->output_q) > 0) { in sink_input_pop_cb()
632 //pa_log_debug("qsize is %ld", pa_memblockq_get_length(u->output_q)); in sink_input_pop_cb()
758 max_rewrite = nbytes + pa_memblockq_get_length(u->input_q); in sink_input_process_rewind_cb()
759 //PA_MIN(pa_memblockq_get_length(u->input_q), nbytes); in sink_input_process_rewind_cb()
|
| H A D | module-remap-sink.c | 94 pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_input->sink->sample_spec); in sink_process_msg()
|
| H A D | module-remap-source.c | 102 pa_bytes_to_usec(pa_memblockq_get_length(u->source_output->thread_info.delay_memblockq), &u->source_output->source->sample_spec); in source_process_msg_cb()
|
| H A D | module-ladspa-sink.c | 362 pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_input->sink->sample_spec); in sink_process_msg_cb()
431 pa_memblockq_get_length(u->memblockq), true, false, false); in sink_request_rewind_cb()
539 max_rewrite = nbytes + pa_memblockq_get_length(u->memblockq); in sink_input_process_rewind_cb()
|
| H A D | module-combine-sink.c | 739 *r = pa_bytes_to_usec(pa_memblockq_get_length(o->memblockq), &o->sink_input->sample_spec); in sink_input_process_msg()
767 length = pa_memblockq_get_length(o->sink_input->thread_info.render_memblockq); in sink_input_process_msg()
769 o->latency_snapshot.output_memblockq_size = pa_memblockq_get_length(o->memblockq); in sink_input_process_msg()
|
| H A D | module-virtual-source.c | 178 pa_bytes_to_usec(pa_memblockq_get_length(u->source_output->thread_info.delay_memblockq), &u->source_output->source->sample_spec); in source_process_msg_cb()
|
| /third_party/pulseaudio/src/pulsecore/ |
| H A D | memblockq.c | 380 return pa_memblockq_get_length(bq) < bq->prebuf; in pa_memblockq_prebuf_active()
390 if (pa_memblockq_get_length(bq) < bq->prebuf) in update_prebuf()
600 if (pa_memblockq_get_length(bq) <= 0) in pa_memblockq_is_readable()
606 size_t pa_memblockq_get_length(pa_memblockq *bq) { in pa_memblockq_get_length() function
842 if (bq->prebuf <= 0 || pa_memblockq_get_length(bq) >= bq->prebuf) in pa_memblockq_set_prebuf()
|
| H A D | memblockq.h | 191 size_t pa_memblockq_get_length(pa_memblockq *bq);
|
| H A D | protocol-http.c | 247 return pa_bytes_to_usec(pa_memblockq_get_length(c->output_memblockq), &c->source_output->sample_spec); in source_output_get_latency_cb()
528 pa_iochannel_socket_set_sndbuf(c->io, pa_memblockq_get_length(c->output_memblockq)); in line_drain_callback()
|
| H A D | protocol-simple.c | 327 /* pa_log("got data, %u", pa_memblockq_get_length(c->input_memblockq)); */ in sink_input_process_msg()
340 *r = pa_bytes_to_usec(pa_memblockq_get_length(c->input_memblockq), &c->sink_input->sample_spec); in sink_input_process_msg()
446 return pa_bytes_to_usec(pa_memblockq_get_length(c->output_memblockq), &c->source_output->sample_spec); in source_output_get_latency_cb()
|
| H A D | sink-input.c | 1204 lbq = pa_memblockq_get_length(i->thread_info.render_memblockq); in pa_sink_input_process_rewind()
2117 to_push = pa_memblockq_get_length(i->thread_info.history_memblockq); in restore_render_memblockq()
2366 r[0] += pa_bytes_to_usec(pa_memblockq_get_length(i->thread_info.render_memblockq), &i->sink->sample_spec); in pa_sink_input_process_msg()
2465 lbq = pa_memblockq_get_length(i->thread_info.render_memblockq); in pa_sink_input_request_rewind()
|
| H A D | source-output.c | 798 while ((length = pa_memblockq_get_length(o->thread_info.delay_memblockq)) > limit) { in pa_source_output_push()
881 length = pa_memblockq_get_length(o->thread_info.delay_memblockq); in pa_source_output_process_rewind()
1732 r[0] += pa_bytes_to_usec(pa_memblockq_get_length(o->thread_info.delay_memblockq), &o->source->sample_spec); in pa_source_output_process_msg()
|
| H A D | protocol-esound.c | 1346 /* pa_log("got data, %u", pa_memblockq_get_length(c->input_memblockq)); */ in sink_input_process_msg()
1359 *r = pa_bytes_to_usec(pa_memblockq_get_length(c->input_memblockq), &c->sink_input->sample_spec); in sink_input_process_msg()
1461 return pa_bytes_to_usec(pa_memblockq_get_length(c->output_memblockq), &c->source_output->sample_spec); in source_output_get_latency_cb()
|
| H A D | protocol-native.c | 1110 /* pa_log("%lu vs. %lu", (unsigned long) pa_memblockq_get_length(s->memblockq), (unsigned long) pa_memblockq_get_prebuf(s->memblockq)); */ in handle_seek()
1250 s->render_memblockq_length = pa_memblockq_get_length(s->sink_input->thread_info.render_memblockq); in sink_input_process_msg()
1281 *r = pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &i->sample_spec); in sink_input_process_msg()
1372 pa_log("%s, pop(): %lu", pa_proplist_gets(i->proplist, PA_PROP_MEDIA_NAME), (unsigned long) pa_memblockq_get_length(s->memblockq)); in sink_input_pop_cb()
1602 /*pa_log("get_latency: %u", pa_memblockq_get_length(s->memblockq));*/ in source_output_get_latency_cb()
1604 return pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &o->sample_spec); in source_output_get_latency_cb()
|
| /third_party/pulseaudio/src/modules/echo-cancel/ |
| H A D | module-echo-cancel.c | 421 pa_bytes_to_usec(pa_memblockq_get_length(u->source_output->thread_info.delay_memblockq), &u->source_output->source->sample_spec) + in source_process_msg_cb()
461 pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_input->sink->sample_spec); in sink_process_msg_cb()
744 rlen = pa_memblockq_get_length(u->source_memblockq); in do_push_drift_comp()
745 plen = pa_memblockq_get_length(u->sink_memblockq); in do_push_drift_comp()
836 rlen = pa_memblockq_get_length(u->source_memblockq); in do_push()
837 plen = pa_memblockq_get_length(u->sink_memblockq); in do_push()
922 rlen = pa_memblockq_get_length(u->source_memblockq); in source_output_push_cb()
923 plen = pa_memblockq_get_length(u->sink_memblockq); in source_output_push_cb()
1030 (long long) pa_memblockq_get_length (u->source_memblockq)); in source_output_process_rewind_cb()
1062 delay = pa_memblockq_get_length( in source_output_snapshot_within_thread()
[all...] |
| /third_party/pulseaudio/src/tests/ |
| H A D | memblockq-test.c | 126 size_t length = pa_memblockq_get_length(bq); in check_queue_invariants()
210 ck_assert_int_eq(pa_memblockq_get_length(bq), 0); in START_TEST()
370 ck_assert_int_eq(pa_memblockq_get_length(bq), 32); in START_TEST()
|
| /third_party/pulseaudio/src/modules/rtp/ |
| H A D | rtp-native.c | 96 if (pa_memblockq_get_length(q) < c->mtu) in pa_rtp_send()
163 if (r < 0 || pa_memblockq_get_length(q) < c->mtu) in pa_rtp_send()
|
| H A D | rtp-gstreamer.c | 282 if (pa_memblockq_get_length(q) < c->mtu) in pa_rtp_send()
344 if (r < 0 || pa_memblockq_get_length(q) < c->mtu) in pa_rtp_send()
|
| H A D | module-rtp-recv.c | 139 *((pa_usec_t*) data) = pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &s->sink_input->sample_spec); in sink_input_process_msg()
289 render_delay = pa_bytes_to_usec(pa_memblockq_get_length(s->sink_input->thread_info.render_memblockq), &s->sink_input->sink->sample_spec); in rtpoll_work_cb()
|
| H A D | module-rtp-send.c | 127 *((pa_usec_t*) data) = pa_bytes_to_usec(pa_memblockq_get_length(u->memblockq), &u->source_output->sample_spec); in source_output_process_msg()
|
| /third_party/pulseaudio/src/pulse/ |
| H A D | stream.c | 1737 return pa_memblockq_get_length(s->record_memblockq); in pa_stream_readable_size()
1972 i->read_index -= (int64_t) pa_memblockq_get_length(o->stream->record_memblockq); in stream_get_timing_info_callback()
|
| H A D | context.c | 445 if ((l = pa_memblockq_get_length(s->record_memblockq)) > 0) in pstream_memblock_callback()
|