diff options
author | David Henningsson <diwic@ubuntu.com> | 2010-05-03 11:41:47 +0200 |
---|---|---|
committer | Lennart Poettering <lennart@poettering.net> | 2010-05-08 01:30:55 +0200 |
commit | f081c152f3d5f6a70edc6b7369445229b4f6a1b8 (patch) | |
tree | 9174565577f6cf833adbccb8980444d677b7d437 /src/modules/jack | |
parent | cdc2769162c7e4d4bbab0b221829c0caca31c43d (diff) |
jack: Prevent crash on jack server shutdown
Diffstat (limited to 'src/modules/jack')
-rw-r--r-- | src/modules/jack/module-jack-sink.c | 7 | ||||
-rw-r--r-- | src/modules/jack/module-jack-source.c | 6 |
2 files changed, 7 insertions, 6 deletions
diff --git a/src/modules/jack/module-jack-sink.c b/src/modules/jack/module-jack-sink.c index 4a0d3847..08a8befa 100644 --- a/src/modules/jack/module-jack-sink.c +++ b/src/modules/jack/module-jack-sink.c @@ -147,6 +147,7 @@ static int sink_process_msg(pa_msgobject *o, int code, void *data, int64_t offse pa_sample_spec ss; /* Humm, we're not RUNNING, hence let's write some silence */ + /* This can happen if we're paused, or during shutdown (when we're unlinked but jack is still running). */ ss = u->sink->sample_spec; ss.channels = 1; @@ -480,12 +481,12 @@ void pa__done(pa_module*m) { if (!(u = m->userdata)) return; - if (u->client) - jack_client_close(u->client); - if (u->sink) pa_sink_unlink(u->sink); + if (u->client) + jack_client_close(u->client); + if (u->thread) { pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); pa_thread_free(u->thread); diff --git a/src/modules/jack/module-jack-source.c b/src/modules/jack/module-jack-source.c index 2d152b38..6b128402 100644 --- a/src/modules/jack/module-jack-source.c +++ b/src/modules/jack/module-jack-source.c @@ -425,12 +425,12 @@ void pa__done(pa_module*m) { if (!(u = m->userdata)) return; - if (u->client) - jack_client_close(u->client); - if (u->source) pa_source_unlink(u->source); + if (u->client) + jack_client_close(u->client); + if (u->thread) { pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); pa_thread_free(u->thread); |