diff options
| author | Tanu Kaskinen <tanuk@iki.fi> | 2007-09-23 14:51:07 +0000 |
|---|---|---|
| committer | Tanu Kaskinen <tanuk@iki.fi> | 2007-09-23 14:51:07 +0000 |
| commit | de079ac40474fdf845de799b6ced5892282a70fe (patch) | |
| tree | b94e9378d2a033a7ae221e53be7da7afe5a33698 | |
| parent | 7bcbf16e9483ea111d6c708015b5c0154edca1d4 (diff) | |
Added an assertion for the case when the sink programmer hasn't installed the thread_mq properly.
git-svn-id: file:///home/lennart/svn/public/pulseaudio/branches/lennart@1890 fefdeb5f-60dc-0310-8127-8f9354f1896f
| -rw-r--r-- | src/pulsecore/protocol-native.c | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/pulsecore/protocol-native.c b/src/pulsecore/protocol-native.c index 24f5997e..c282c177 100644 --- a/src/pulsecore/protocol-native.c +++ b/src/pulsecore/protocol-native.c @@ -792,8 +792,10 @@ static void request_bytes(playback_stream *s) { minreq = pa_memblockq_get_minreq(s->memblockq); previous_missing = pa_atomic_add(&s->missing, delta); - if (previous_missing < minreq && previous_missing+delta >= minreq) + if (previous_missing < minreq && previous_missing+delta >= minreq) { + pa_assert(pa_thread_mq_get()); pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(s), PLAYBACK_STREAM_MESSAGE_REQUEST_DATA, NULL, 0, NULL, NULL); + } } static void send_memblock(connection *c) { |