Lines Matching refs:thread_info
189 } thread_info; member
393 pa_assert(u->sink->thread_info.state == PA_SINK_RUNNING); in process_render_null()
395 if (u->thread_info.in_null_mode) in process_render_null()
396 u->thread_info.timestamp = now; in process_render_null()
398 while (u->thread_info.timestamp < now + u->block_usec) { in process_render_null()
401 pa_sink_render(u->sink, u->sink->thread_info.max_request, &chunk); in process_render_null()
404 u->thread_info.counter += chunk.length; in process_render_null()
407 u->thread_info.timestamp += pa_bytes_to_usec(chunk.length, &u->sink->sample_spec); in process_render_null()
411 if (ate >= u->sink->thread_info.max_request) in process_render_null()
418 pa_smoother_2_put(u->thread_info.smoother, now, in process_render_null()
419 … u->thread_info.counter - pa_usec_to_bytes(u->thread_info.timestamp - now, &u->sink->sample_spec)); in process_render_null()
421 pa_smoother_put(u->thread_info.smoother, now, in process_render_null()
422 …pa_bytes_to_usec(u->thread_info.counter, &u->sink->sample_spec) - (u->thread_info.timestamp - now)… in process_render_null()
438 u->thread_info.timestamp = pa_rtclock_now(); in thread_func()
439 u->thread_info.in_null_mode = false; in thread_func()
444 if (PA_UNLIKELY(u->sink->thread_info.rewind_requested)) in thread_func()
448 if (u->sink->thread_info.state == PA_SINK_RUNNING && !u->thread_info.active_outputs) { in thread_func()
453 if (!u->thread_info.in_null_mode || u->thread_info.timestamp <= now) in thread_func()
456 pa_rtpoll_set_timer_absolute(u->rtpoll, u->thread_info.timestamp); in thread_func()
457 u->thread_info.in_null_mode = true; in thread_func()
460 u->thread_info.in_null_mode = false; in thread_func()
493 if (!pa_atomic_load(&u->thread_info.running)) in render_memblock()
503 u->thread_info.render_timestamp = pa_rtclock_now(); in render_memblock()
512 u->thread_info.counter += chunk.length; in render_memblock()
516 PA_LLIST_FOREACH(j, u->thread_info.active_outputs) { in render_memblock()
546 if (pa_atomic_load(&o->userdata->thread_info.running)) in request_memblock()
620 fix = i->sink->thread_info.fixed_latency; in sink_input_update_sink_latency_range_cb()
625 min = i->sink->thread_info.min_latency; in sink_input_update_sink_latency_range_cb()
626 max = i->sink->thread_info.max_latency; in sink_input_update_sink_latency_range_cb()
654 i->sink->thread_info.rtpoll, in sink_input_attach_cb()
659 i->sink->thread_info.rtpoll, in sink_input_attach_cb()
664 i->sink->thread_info.rtpoll, in sink_input_attach_cb()
674 fix = i->sink->thread_info.fixed_latency; in sink_input_attach_cb()
678 min = i->sink->thread_info.min_latency; in sink_input_attach_cb()
679 max = i->sink->thread_info.max_latency; in sink_input_attach_cb()
748 if (o->sink_input->sink->thread_info.state == PA_SINK_RUNNING) { in sink_input_process_msg()
767 length = pa_memblockq_get_length(o->sink_input->thread_info.render_memblockq); in sink_input_process_msg()
775 …latency_snapshot.sink_latency += pa_resampler_get_delay_usec(o->sink_input->thread_info.resampler); in sink_input_process_msg()
872 if (new_state == s->thread_info.state) in sink_set_state_in_io_thread_cb()
876 pa_atomic_store(&u->thread_info.running, running); in sink_set_state_in_io_thread_cb()
879 u->thread_info.render_timestamp = 0; in sink_set_state_in_io_thread_cb()
881 pa_smoother_2_resume(u->thread_info.smoother, pa_rtclock_now()); in sink_set_state_in_io_thread_cb()
883 pa_smoother_2_pause(u->thread_info.smoother, pa_rtclock_now()); in sink_set_state_in_io_thread_cb()
885 pa_smoother_resume(u->thread_info.smoother, pa_rtclock_now(), true); in sink_set_state_in_io_thread_cb()
887 pa_smoother_pause(u->thread_info.smoother, pa_rtclock_now());
904 PA_LLIST_FOREACH(o, u->thread_info.active_outputs) { in update_max_request()
928 PA_LLIST_FOREACH(o, u->thread_info.active_outputs) { in update_latency_range()
962 PA_LLIST_PREPEND(struct output, o->userdata->thread_info.active_outputs, o); in output_add_within_thread()
980 o->receive_counter = o->userdata->thread_info.counter; in output_add_within_thread()
988 PA_LLIST_REMOVE(struct output, o->userdata->thread_info.active_outputs, o); in output_remove_within_thread()
1017 u->block_usec = s->thread_info.max_latency; in sink_update_requested_latency()
1022 PA_LLIST_FOREACH(o, u->thread_info.active_outputs) { in sink_update_requested_latency()
1039 …*delay = pa_smoother_2_get_delay(u->thread_info.smoother, pa_rtclock_now(), u->thread_info.counter… in sink_process_msg()
1044 y = pa_smoother_get(u->thread_info.smoother, x); in sink_process_msg()
1046 c = pa_bytes_to_usec(u->thread_info.counter, &u->sink->sample_spec); in sink_process_msg()
1075 …pa_smoother_2_put(u->thread_info.smoother, u->thread_info.snapshot_time, (int64_t)u->thread_info.s… in sink_process_msg()
1082 x = u->thread_info.snapshot_time; in sink_process_msg()
1083 y = pa_bytes_to_usec(u->thread_info.snapshot_counter, &u->sink->sample_spec); in sink_process_msg()
1090 pa_smoother_put(u->thread_info.smoother, x, y); in sink_process_msg()
1098 rdata->timestamp = u->thread_info.render_timestamp; in sink_process_msg()
1099 rdata->send_counter = u->thread_info.counter; in sink_process_msg()
1100 u->thread_info.snapshot_counter = u->thread_info.counter; in sink_process_msg()
1101 u->thread_info.snapshot_time = u->thread_info.render_timestamp; in sink_process_msg()
1511 u->thread_info.smoother = pa_smoother_new( in pa__init()
1628 …u->thread_info.smoother = pa_smoother_2_new(u->adjust_time + 5*PA_USEC_PER_SEC, pa_rtclock_now(), … in pa__init()
1644 u->default_min_latency = u->sink->thread_info.min_latency; in pa__init()
1645 u->default_max_latency = u->sink->thread_info.max_latency; in pa__init()
1646 u->block_usec = u->sink->thread_info.max_latency; in pa__init()
1700 u->thread_info.render_timestamp = 0; in pa__init()
1771 if (u->thread_info.smoother) in pa__done()
1773 pa_smoother_2_free(u->thread_info.smoother); in pa__done()
1775 pa_smoother_free(u->thread_info.smoother); in pa__done()