From bf8ced4e3d6f4973a01e19ab91ad9989ec76af21 Mon Sep 17 00:00:00 2001
From: Thibaut Mattern <tmattern@users.sourceforge.net>
Date: Mon, 18 Oct 2004 21:55:00 +0000
Subject: Fix resync code performance problem. Should fix deadlocks detected by
 the testsuite with this stream "mpg/small1080.mpg".

CVS patchset: 7050
CVS date: 2004/10/18 21:55:00
---
 src/demuxers/demux_mpeg.c | 30 +++++++++++++++++++++++++++---
 1 file changed, 27 insertions(+), 3 deletions(-)

(limited to 'src')

diff --git a/src/demuxers/demux_mpeg.c b/src/demuxers/demux_mpeg.c
index 9ecbbce0c..f480608a2 100644
--- a/src/demuxers/demux_mpeg.c
+++ b/src/demuxers/demux_mpeg.c
@@ -19,7 +19,7 @@
  */
 
 /*
- * $Id: demux_mpeg.c,v 1.143 2004/06/14 13:43:11 mroi Exp $
+ * $Id: demux_mpeg.c,v 1.144 2004/10/18 21:55:00 tmattern Exp $
  *
  * demultiplexer for mpeg 1/2 program streams
  * reads streams of variable blocksizes
@@ -905,9 +905,33 @@ static uint32_t parse_pack_preview (demux_mpeg_t *this, int *num_buffers) {
 
 static void demux_mpeg_resync (demux_mpeg_t *this, uint32_t buf) {
 
-  while ((buf !=0x000001ba) && (this->status == DEMUX_OK)) {
+  if (INPUT_IS_SEEKABLE(this->input)) {
+    uint8_t dummy_buf[4096];
+    off_t len, pos;
+
+    /* fast resync, read 4K block at once */
+    pos = 0;
+    len = 0;
+    while ((buf != 0x000001ba) && (this->status == DEMUX_OK)) {
+      if (pos == len) {
+	len = this->input->read(this->input, dummy_buf, sizeof(dummy_buf));
+        pos = 0;
+        if (len == 0) {
+          this->status = DEMUX_FINISHED;
+	  break;
+	}
+      }
+      buf = (buf << 8) | dummy_buf[pos];
+      pos++;
+    }
+    /* seek back to the pos of the 0x00001ba tag */
+    this->input->seek(this->input, pos-len, SEEK_CUR);
 
-    buf = (buf << 8) | read_bytes (this, 1);
+  } else {
+    /* slow resync */
+    while ((buf !=0x000001ba) && (this->status == DEMUX_OK)) {
+      buf = (buf << 8) | read_bytes (this, 1);
+    }
   }
 }
 
-- 
cgit v1.2.3