Properly flush packet queues when at EOF

Note: the previous flush method was renamed to clear. Flushing a queue allows
consumers to retrieve queued packets, but not expect any more to come in.

apps/openmw/mwrender/videoplayer.cpp

@@ -29,12 +29,13 @@ enum {
 
 struct PacketQueue {
     PacketQueue()
-      : first_pkt(NULL), last_pkt(NULL), nb_packets(0), size(0)
+      : first_pkt(NULL), last_pkt(NULL), flushing(false), nb_packets(0), size(0)
     { }
     ~PacketQueue()
-    { flush(); }
+    { clear(); }
 
     AVPacketList *first_pkt, *last_pkt;
+    volatile bool flushing;
     int nb_packets;
     int size;
 
@@ -45,6 +46,7 @@ struct PacketQueue {
     int get(AVPacket *pkt, VideoState *is);
 
     void flush();
+    void clear();
 };
 
 struct VideoPicture {
@@ -202,6 +204,8 @@ int PacketQueue::get(AVPacket *pkt, VideoState *is)
             return 1;
         }
 
+        if(this->flushing)
+            break;
         this->cond.wait(lock);
     }
 
@@ -209,6 +213,12 @@ int PacketQueue::get(AVPacket *pkt, VideoState *is)
 }
 
 void PacketQueue::flush()
+{
+    this->flushing = true;
+    this->cond.notify_one();
+}
+
+void PacketQueue::clear()
 {
     AVPacketList *pkt, *pkt1;
 
@@ -753,7 +763,10 @@ void VideoState::decode_thread_loop(VideoState *self)
             else
                 av_free_packet(packet);
         }
+
         /* all done - wait for it */
+        self->videoq.flush();
+        self->audioq.flush();
         while(!self->quit)
         {
             // EOF reached, all packets processed, we can exit now