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

module-waveout: Move thread creation

Browse source
This commit is contained in:
Maarten Bosmans 2011-03-11 15:41:29 +01:00
parent 030f32fe6f
commit 72de043234
1 changed files with 13 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

22
src/modules/module-waveout.c
View file

@ -650,7 +650,7 @@ int pa__init(pa_module *m) {
pa_assert(u->ihdrs);
u->ohdrs = pa_xmalloc0(sizeof(WAVEHDR) * u->fragments);
pa_assert(u->ohdrs);
for (i = 0;i < u->fragments;i++) {
for (i = 0; i < u->fragments; i++) {
u->ihdrs[i].dwBufferLength = u->fragment_size;
u->ohdrs[i].dwBufferLength = u->fragment_size;
u->ihdrs[i].lpData = pa_xmalloc(u->fragment_size);
@ -668,22 +668,26 @@ int pa__init(pa_module *m) {
u->rtpoll = pa_rtpoll_new();
pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll);
if (!(u->thread = pa_thread_new("waveout-source", thread_func, u))) {
pa_log("Failed to create thread.");
goto fail;
}
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);
}
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);
}
if (!(u->thread = pa_thread_new("waveout", thread_func, u))) {
pa_log("Failed to create thread.");
goto fail;
}
if (u->sink)
pa_sink_put(u->sink);
if (u->source)
pa_source_put(u->source);
return 0;
fail:
@ -712,7 +716,7 @@ void pa__done(pa_module *m) {
pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL);
if (u->thread)
pa_thread_free(u->thread);
pa_thread_free(u->thread);
pa_thread_mq_done(&u->thread_mq);
if (u->sink)
@ -733,7 +737,7 @@ void pa__done(pa_module *m) {
waveOutClose(u->hwo);
}
for (i = 0;i < u->fragments;i++) {
for (i = 0; i < u->fragments; i++) {
pa_xfree(u->ihdrs[i].lpData);
pa_xfree(u->ohdrs[i].lpData);
}