Nikolay Sivov : mfreadwrite: Request one sample at a time from the stream.

[Alexandre Julliard]

Module: wine
Branch: master
Commit: 767744513e7d4c40f76a0ad0e2e40fc933081919
URL:    https://source.winehq.org/git/wine.git/?a=commit;h=767744513e7d4c40f76a0ad0e...

Author: Nikolay Sivov <nsivov(a)codeweavers.com>
Date:   Wed Mar 25 14:39:59 2020 +0300

mfreadwrite: Request one sample at a time from the stream.

Signed-off-by: Nikolay Sivov <nsivov(a)codeweavers.com>
Signed-off-by: Alexandre Julliard <julliard(a)winehq.org>

---

 dlls/mfreadwrite/main.c | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/dlls/mfreadwrite/main.c b/dlls/mfreadwrite/main.c
index ee4d826519..af9bea34ac 100644
--- a/dlls/mfreadwrite/main.c
+++ b/dlls/mfreadwrite/main.c
@@ -94,6 +94,11 @@ enum media_source_state
     SOURCE_STATE_STARTED,
 };
 
+enum media_stream_flags
+{
+    STREAM_FLAG_SAMPLE_REQUESTED = 0x1,
+};
+
 struct media_stream
 {
     IMFMediaStream *stream;
@@ -107,6 +112,7 @@ struct media_stream
     enum media_stream_state state;
     BOOL selected;
     BOOL presented;
+    DWORD flags;
 };
 
 struct source_reader
@@ -507,6 +513,7 @@ static HRESULT source_reader_media_sample_handler(struct source_reader *reader,
         {
             EnterCriticalSection(&reader->streams[i].cs);
 
+            reader->streams[i].flags &= ~STREAM_FLAG_SAMPLE_REQUESTED;
             hr = source_reader_process_sample(&reader->streams[i], sample);
 
             LeaveCriticalSection(&reader->streams[i].cs);
@@ -1235,10 +1242,12 @@ static HRESULT source_reader_read_sample(struct source_reader *reader, DWORD ind
         {
             while (list_empty(&stream->responses) && stream->state != STREAM_STATE_EOS)
             {
-                if (stream->stream)
+                if (stream->stream && !(stream->flags & STREAM_FLAG_SAMPLE_REQUESTED))
                 {
                     if (FAILED(hr = IMFMediaStream_RequestSample(stream->stream, NULL)))
                         WARN("Sample request failed, hr %#x.\n", hr);
+                    else
+                        stream->flags |= STREAM_FLAG_SAMPLE_REQUESTED;
                 }
                 SleepConditionVariableCS(&stream->sample_event, &stream->cs, INFINITE);
             }