Lines Matching refs:userdata
94 struct userdata *userdata;
144 struct userdata {
232 min_cycles_1 = (double)abs(latency_difference_usec) / o->userdata->adjust_time / 0.002 + 1;
233 new_rate_1 = old_rate + base_rate * (double)latency_difference_usec / min_cycles_1 / o->userdata->adjust_time;
237 min_cycles_2 = (double)abs(latency_difference_usec) / o->userdata->adjust_time / 0.01 + 1;
238 new_rate_2 = (double)base_rate * (1.0 + (double)latency_difference_usec / min_cycles_2 / o->userdata->adjust_time);
248 static void adjust_rates(struct userdata *u) {
364 static void time_callback(pa_mainloop_api *a, pa_time_event *e, const struct timeval *t, void *userdata) {
365 struct userdata *u = userdata;
389 static void process_render_null(struct userdata *u, pa_usec_t now) {
426 static void thread_func(void *userdata) {
427 struct userdata *u = userdata;
484 static void render_memblock(struct userdata *u, struct output *o, size_t length) {
533 pa_sink_assert_ref(o->userdata->sink);
546 if (pa_atomic_load(&o->userdata->thread_info.running))
547 pa_asyncmsgq_send(o->outq, PA_MSGOBJECT(o->userdata->sink), SINK_MESSAGE_NEED, o, (int64_t) length, NULL);
555 pa_assert_se(o = i->userdata);
580 pa_assert_se(o = i->userdata);
590 pa_assert_se(o = i->userdata);
600 pa_assert_se(o = i->userdata);
607 pa_asyncmsgq_post(o->outq, PA_MSGOBJECT(o->userdata->sink), SINK_MESSAGE_UPDATE_MAX_REQUEST, NULL, 0, NULL, NULL);
618 pa_assert_se(o = i->userdata);
636 pa_asyncmsgq_post(o->outq, PA_MSGOBJECT(o->userdata->sink), SINK_MESSAGE_UPDATE_LATENCY_RANGE, NULL, 0, NULL, NULL);
646 pa_assert_se(o = i->userdata);
687 pa_asyncmsgq_send(o->userdata->sink->asyncmsgq, PA_MSGOBJECT(o->userdata->sink), SINK_MESSAGE_ADD_OUTPUT, o, 0, NULL);
695 pa_assert_se(o = i->userdata);
699 pa_asyncmsgq_send(o->userdata->sink->asyncmsgq, PA_MSGOBJECT(o->userdata->sink), SINK_MESSAGE_REMOVE_OUTPUT, o, 0, NULL);
723 pa_assert_se(o = i->userdata);
725 pa_module_unload_request(o->userdata->module, true);
726 pa_idxset_remove_by_data(o->userdata->outputs, o, NULL);
732 struct output *o = PA_SINK_INPUT(obj)->userdata;
789 static void suspend(struct userdata *u) {
803 static void unsuspend(struct userdata *u) {
818 struct userdata *u;
821 pa_assert_se(u = sink->userdata);
864 struct userdata *u;
868 pa_assert_se(u = s->userdata);
894 static void update_max_request(struct userdata *u) {
919 static void update_latency_range(struct userdata *u) {
962 PA_LLIST_PREPEND(struct output, o->userdata->thread_info.active_outputs, o);
969 o->userdata->rtpoll,
973 o->userdata->rtpoll,
977 o->userdata->rtpoll,
980 o->receive_counter = o->userdata->thread_info.counter;
988 PA_LLIST_REMOVE(struct output, o->userdata->thread_info.active_outputs, o);
1008 struct userdata *u;
1012 pa_assert_se(u = s->userdata);
1031 struct userdata *u = PA_SINK(o)->userdata;
1119 static void update_description(struct userdata *u) {
1155 struct userdata *u;
1163 u = o->userdata;
1196 o->sink_input->userdata = o;
1204 static struct output *output_new(struct userdata *u, pa_sink *sink) {
1212 o->userdata = u;
1260 update_description(o->userdata);
1343 if (PA_SINK_IS_OPENED(o->userdata->sink->state))
1350 static bool is_suitable_sink(struct userdata *u, pa_sink *s) {
1372 static pa_hook_result_t sink_put_hook_cb(pa_core *c, pa_sink *s, struct userdata* u) {
1407 static struct output* find_output(struct userdata *u, pa_sink *s) {
1425 static pa_hook_result_t sink_unlink_hook_cb(pa_core *c, pa_sink *s, struct userdata* u) {
1447 static pa_hook_result_t sink_state_changed_hook_cb(pa_core *c, pa_sink *s, struct userdata* u) {
1465 struct userdata *u;
1492 m->userdata = u = pa_xnew0(struct userdata, 1);
1635 u->sink->userdata = u;
1731 struct userdata *u;
1735 if (!(u = m->userdata))