switch ((pa_sink_message_t) code) {
case PA_SINK_MESSAGE_ADD_INPUT: {
- pa_sink_input *i = userdata;
+ pa_sink_input *i = PA_SINK_INPUT(userdata);
pa_hashmap_put(s->thread_info.inputs, PA_UINT32_TO_PTR(i->index), pa_sink_input_ref(i));
/* Since the caller sleeps in pa_sink_input_put(), we can
}
case PA_SINK_MESSAGE_REMOVE_INPUT: {
- pa_sink_input *i = userdata;
+ pa_sink_input *i = PA_SINK_INPUT(userdata);
/* Since the caller sleeps in pa_sink_input_disconnect(),
* we can safely access data outside of thread_info even
switch ((pa_source_message_t) code) {
case PA_SOURCE_MESSAGE_ADD_OUTPUT: {
- pa_source_output *o = userdata;
+ pa_source_output *o = PA_SOURCE_OUTPUT(userdata);
pa_hashmap_put(s->thread_info.outputs, PA_UINT32_TO_PTR(o->index), pa_source_output_ref(o));
return 0;
}
case PA_SOURCE_MESSAGE_REMOVE_OUTPUT: {
- pa_source_output *o = userdata;
+ pa_source_output *o = PA_SOURCE_OUTPUT(userdata);
if (pa_hashmap_remove(s->thread_info.outputs, PA_UINT32_TO_PTR(o->index)))
pa_source_output_unref(o);