commit 2734e6332ccceb35182c89fc8cc9d222a0b05dd0
author Maarten Lankhorst <m.b.lankhorst@gmail.com> Wed Apr 09 12:07:14 2008 -0700
committer Alexandre Julliard <julliard@winehq.org> Thu Apr 10 09:50:48 2008 +0200
tree 1386ac31fd35c8a7a6692e0a5b7c6296bad95558
parent 43f9fff0a0237efa88de16e8a1ba7da9a58b09d3

quartz: Implement stop position in the mpeg splitter.

dlls/quartz/mpegsplit.c

diff --git a/dlls/quartz/mpegsplit.c b/dlls/quartz/mpegsplit.c
index 5991795..7577174 100644
--- a/dlls/quartz/mpegsplit.c
+++ b/dlls/quartz/mpegsplit.c
@@ -4,6 +4,7 @@
  * Copyright 2003 Robert Shearman
  * Copyright 2004-2005 Christian Costa
  * Copyright 2007 Chris Robinson
+ * Copyright 2008 Maarten Lankhorst
  *
  * This library is free software; you can redistribute it and/or
  * modify it under the terms of the GNU Lesser General Public
@@ -426,16 +427,22 @@
         This->remaining_bytes = 0;
 
         This->Parser.pInputPin->rtCurrent = MEDIATIME_FROM_BYTES(BYTES_FROM_MEDIATIME(tStop) - cbSrcStream);
-        if (This->pCurrentSample)
+
+        /* If set to S_FALSE we keep the sample, to transmit it next time */
+        if (hr != S_FALSE && This->pCurrentSample)
         {
             IMediaSample_SetActualDataLength(This->pCurrentSample, 0);
             IMediaSample_Release(This->pCurrentSample);
             This->pCurrentSample = NULL;
         }
+
+        /* Sample was rejected because of whatever reason (paused/flushing/etc), no need to terminate the processing */
+        if (hr == S_FALSE)
+            hr = S_OK;
         break;
     }
 
-    if (BYTES_FROM_MEDIATIME(tStop) >= This->EndOfFile)
+    if (BYTES_FROM_MEDIATIME(tStop) >= This->EndOfFile || This->position >= This->Parser.mediaSeeking.llStop)
     {
         int i;
 
@@ -742,6 +749,10 @@
             TRACE("Duration: %d seconds\n", (DWORD)(duration / 10000000));
             TRACE("Parsing took %u ms\n", GetTickCount() - ticks);
             This->duration = duration;
+
+            This->Parser.mediaSeeking.llCurrent = 0;
+            This->Parser.mediaSeeking.llDuration = duration;
+            This->Parser.mediaSeeking.llStop = duration;
             break;
         }
         case MPEG_VIDEO_HEADER:
@@ -829,6 +840,7 @@
 
         TRACE("Moving sound to %08u bytes!\n", (DWORD)bytepos);
 
+        EnterCriticalSection(&pin->thread_lock);
         IPin_BeginFlush((IPin *)pin);
 
         /* Make sure this is done while stopped, BeginFlush takes care of this */
@@ -848,6 +860,7 @@
 
         TRACE("Done flushing\n");
         IPin_EndFlush((IPin *)pin);
+        LeaveCriticalSection(&pin->thread_lock);
     }
     return hr;
 }