[pulseaudio-commits] r1890 - /branches/lennart/src/pulsecore/protocol-native.c

[svnmailer-noreply at 0pointer.de]

Author: tanuk
Date: Sun Sep 23 16:51:07 2007
New Revision: 1890

URL: http://0pointer.de/cgi-bin/viewcvs.cgi?rev=1890&root=pulseaudio&view=rev
Log:
Added an assertion for the case when the sink programmer hasn't installed the thread_mq properly.

Modified:
    branches/lennart/src/pulsecore/protocol-native.c

Modified: branches/lennart/src/pulsecore/protocol-native.c
URL: http://0pointer.de/cgi-bin/viewcvs.cgi/branches/lennart/src/pulsecore/protocol-native.c?rev=1890&root=pulseaudio&r1=1889&r2=1890&view=diff
==============================================================================
--- branches/lennart/src/pulsecore/protocol-native.c (original)
+++ branches/lennart/src/pulsecore/protocol-native.c Sun Sep 23 16:51:07 2007
@@ -792,8 +792,10 @@
     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) {