Ziqing Hui : winegstreamer: Create parser for muxer stream.

[Alexandre Julliard]

Module: wine
Branch: master
Commit: 29a8faf19f9ddc3274150e1bf39a0b154eeebb1e
URL:    https://gitlab.winehq.org/wine/wine/-/commit/29a8faf19f9ddc3274150e1bf39a0b1...

Author: Ziqing Hui 
Date:   Mon Oct 30 09:37:10 2023 +0800

winegstreamer: Create parser for muxer stream.

---

dlls/winegstreamer/wg_muxer.c | 23 ++++++++++++++++++++++-
 1 file changed, 22 insertions(+), 1 deletion(-)

diff --git a/dlls/winegstreamer/wg_muxer.c b/dlls/winegstreamer/wg_muxer.c
index 793444ad243..64a19a2ff44 100644
--- a/dlls/winegstreamer/wg_muxer.c
+++ b/dlls/winegstreamer/wg_muxer.c
@@ -46,7 +46,8 @@ struct wg_muxer_stream
     uint32_t id;

GstPad *my_src;
-    GstCaps *my_src_caps;
+    GstCaps *my_src_caps, *parser_src_caps;
+    GstElement *parser;

struct list entry;
 };
@@ -76,6 +77,8 @@ static gboolean muxer_sink_query_cb(GstPad *pad, GstObject *parent, GstQuery *qu

static void stream_free(struct wg_muxer_stream *stream)
 {
+    if (stream->parser_src_caps)
+        gst_caps_unref(stream->parser_src_caps);
     gst_object_unref(stream->my_src);
     gst_caps_unref(stream->my_src_caps);
     free(stream);
@@ -200,6 +203,22 @@ NTSTATUS wg_muxer_add_stream(void *args)
         goto out;
     gst_pad_set_element_private(stream->my_src, stream);

+    /* Create parser. */
+    if ((stream->parser = find_element(GST_ELEMENT_FACTORY_TYPE_PARSER, stream->my_src_caps, NULL)))
+    {
+        GstPad *parser_src;
+
+        if (!gst_bin_add(GST_BIN(muxer->container), stream->parser)
+                || !link_src_to_element(stream->my_src, stream->parser))
+            goto out;
+
+        parser_src = gst_element_get_static_pad(stream->parser, "src");
+        stream->parser_src_caps = gst_pad_query_caps(parser_src, NULL);
+        GST_INFO("Created parser %"GST_PTR_FORMAT" for stream %u %p.",
+                stream->parser, stream->id, stream);
+        gst_object_unref(parser_src);
+    }
+
     /* Add to muxer stream list. */
     list_add_tail(&muxer->streams, &stream->entry);

@@ -210,6 +229,8 @@ NTSTATUS wg_muxer_add_stream(void *args)
     return STATUS_SUCCESS;

out:
+    if (stream->parser)
+        gst_object_unref(stream->parser);
     if (stream->my_src)
         gst_object_unref(stream->my_src);
     if (template)