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
This commit is contained in:
Tanu Kaskinen 2007-09-23 14:51:07 +00:00
parent 7bcbf16e94
commit de079ac404

View file

@ -792,8 +792,10 @@ static void request_bytes(playback_stream *s) {
minreq = pa_memblockq_get_minreq(s->memblockq); minreq = pa_memblockq_get_minreq(s->memblockq);
previous_missing = pa_atomic_add(&s->missing, delta); 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); 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) { static void send_memblock(connection *c) {