mirrors/pulseaudio
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git synced 2025-11-04 13:29:59 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

bluetooth: fix message queue/rtpoll

Browse source
This commit is contained in:
Lennart Poettering 2009-02-13 00:14:48 +02:00 • committed by Marc-André Lureau
parent a571565f86
commit 0b8a6c66dc
1 changed files with 8 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

16
src/modules/bluetooth/module-bluetooth-device.c
View file

@ -1349,9 +1349,6 @@ static int add_sink(struct userdata *u) {
u->sink->userdata = u; u->sink->userdata = u;
u->sink->parent.process_msg = sink_process_msg; u->sink->parent.process_msg = sink_process_msg;
pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq);
pa_sink_set_rtpoll(u->sink, u->rtpoll);
} }
/* u->sink->get_volume = sink_get_volume_cb; */ /* u->sink->get_volume = sink_get_volume_cb; */
@ -1396,9 +1393,6 @@ static int add_source(struct userdata *u) {
u->source->userdata = u; u->source->userdata = u;
u->source->parent.process_msg = source_process_msg; u->source->parent.process_msg = source_process_msg;
pa_source_set_asyncmsgq(u->source, u->thread_mq.inq);
pa_source_set_rtpoll(u->source, u->rtpoll);
} }
/* u->source->get_volume = source_get_volume_cb; */ /* u->source->get_volume = source_get_volume_cb; */
@ -1559,11 +1553,17 @@ static int start_thread(struct userdata *u) {
return -1; return -1;
} }
if (u->sink) if (u->sink) {
pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq);
pa_sink_set_rtpoll(u->sink, u->rtpoll);
pa_sink_put(u->sink); pa_sink_put(u->sink);
}
if (u->source) if (u->source) {
pa_source_set_asyncmsgq(u->source, u->thread_mq.inq);
pa_source_set_rtpoll(u->source, u->rtpoll);
pa_source_put(u->source); pa_source_put(u->source);
}
return 0; return 0;
} }