Fix crash purging closed queue.

diff --git a/src/framework/mlt_consumer.c b/src/framework/mlt_consumer.c
index 866ebf2b75047e3f5cbc6e048dd386198cc2b01f..5cd7bc6fa405da45b3a05d9cacebc927517d8a2c 100644 (file)
--- a/src/framework/mlt_consumer.c
+++ b/src/framework/mlt_consumer.c
@@ -1226,7 +1226,7 @@ void mlt_consumer_purge( mlt_consumer self )
                if ( self->purge )
                        self->purge( self );
 
-               while ( mlt_deque_count( self->queue ) )
+               while ( self->ahead && mlt_deque_count( self->queue ) )
                        mlt_frame_close( mlt_deque_pop_back( self->queue ) );
                if ( self->ahead && self->real_time )
                {