Akihiro Sagawa : winegstreamer: Seek to the end after MPEG splitter connection.

[Alexandre Julliard]

Module: wine
Branch: master
Commit: 7c03bca53bbd115d58a4a54beb5a8cbf82b9f875
URL:    https://gitlab.winehq.org/wine/wine/-/commit/7c03bca53bbd115d58a4a54beb5a8cb...

Author: Akihiro Sagawa 
Date:   Sun Mar 31 21:02:42 2024 +0900

winegstreamer: Seek to the end after MPEG splitter connection.

Wine-Bug: https://bugs.winehq.org/show_bug.cgi?id=56485

---

dlls/quartz/tests/mpegsplit.c      |  2 +-
 dlls/winegstreamer/quartz_parser.c | 20 +++++++++++++++++++-
 2 files changed, 20 insertions(+), 2 deletions(-)

diff --git a/dlls/quartz/tests/mpegsplit.c b/dlls/quartz/tests/mpegsplit.c
index 8799c6afb8f..3d4ba8b7959 100644
--- a/dlls/quartz/tests/mpegsplit.c
+++ b/dlls/quartz/tests/mpegsplit.c
@@ -2183,7 +2183,7 @@ static void test_video_read_position(void)

hr = IFilterGraph2_ConnectDirect(graph, &testsource.source.pin.IPin_iface, sink, NULL);
     ok(hr == S_OK, "Got hr %#lx.\n", hr);
-    todo_wine ok(testsource.read_position == total, "Got 0x%s, expected 0x%s.\n", wine_dbgstr_longlong(testsource.read_position), wine_dbgstr_longlong(total));
+    ok(testsource.read_position == total, "Got 0x%s, expected 0x%s.\n", wine_dbgstr_longlong(testsource.read_position), wine_dbgstr_longlong(total));

IAsyncReader_Release(testsource.reader);
     IPin_Release(sink);
diff --git a/dlls/winegstreamer/quartz_parser.c b/dlls/winegstreamer/quartz_parser.c
index 32eb6e1a4a0..2c9fb896b1e 100644
--- a/dlls/winegstreamer/quartz_parser.c
+++ b/dlls/winegstreamer/quartz_parser.c
@@ -2380,11 +2380,29 @@ static HRESULT mpeg_splitter_sink_get_media_type(struct strmbase_pin *pin,
     return S_OK;
 }

+static HRESULT mpeg_splitter_sink_connect(struct strmbase_sink *iface, IPin *peer, const AM_MEDIA_TYPE *pmt)
+{
+    struct parser *filter = impl_from_strmbase_sink(iface);
+    HRESULT hr = parser_sink_connect(iface, peer, pmt);
+
+    /* Seek the reader to the end. RE:D Cherish! depends on this. */
+    if (SUCCEEDED(hr)
+            && IsEqualGUID(&pmt->subtype, &MEDIASUBTYPE_MPEG1System)
+            && IsEqualGUID(&pmt->majortype, &MEDIATYPE_Stream))
+    {
+        LONGLONG file_size, unused;
+        IAsyncReader_Length(filter->reader, &file_size, &unused);
+        IAsyncReader_SyncRead(filter->reader, file_size, 0, NULL);
+    }
+
+    return hr;
+}
+
 static const struct strmbase_sink_ops mpeg_splitter_sink_ops =
 {
     .base.pin_query_accept = mpeg_splitter_sink_query_accept,
     .base.pin_get_media_type = mpeg_splitter_sink_get_media_type,
-    .sink_connect = parser_sink_connect,
+    .sink_connect = mpeg_splitter_sink_connect,
     .sink_disconnect = parser_sink_disconnect,
 };