work: fix hang in p-to-p encoding

1 files changed, 9 insertions, 0 deletions

diff --git a/libhb/work.c b/libhb/work.c
index a21481a7c..7a8f1ee19 100644
--- a/libhb/work.c
+++ b/libhb/work.c
@@ -1877,6 +1877,15 @@ void hb_work_loop( void * _w )
     {
         hb_buffer_close( &buf_out );
     }
+
+    // Consume data in incoming fifo till job complete so that
+    // residual data does not stall the pipeline
+    while (!*w->done && w->fifo_in != NULL)
+    {
+        buf_in = hb_fifo_get_wait( w->fifo_in );
+        if ( buf_in != NULL )
+            hb_buffer_close( &buf_in );
+    }
 }
 
 /**