1 files changed, 83 insertions, 0 deletions
diff --git a/filters/f_demux_in.c b/filters/f_demux_in.c
new file mode 100644
index 0000000000..defe68426f
--- /dev/null
+++ b/filters/f_demux_in.c
@@ -0,0 +1,83 @@
+#include "common/common.h"
+#include "demux/demux.h"
+#include "demux/packet.h"
+
+#include "f_demux_in.h"
+#include "filter_internal.h"
+
+struct priv {
+    struct sh_stream *src;
+    bool eof_returned;
+};
+
+static void wakeup(void *ctx)
+{
+    struct mp_filter *f = ctx;
+
+    mp_filter_wakeup(f);
+}
+
+static void process(struct mp_filter *f)
+{
+    struct priv *p = f->priv;
+
+    if (!mp_pin_in_needs_data(f->ppins[0]))
+        return;
+
+    struct demux_packet *pkt = NULL;
+    if (demux_read_packet_async(p->src, &pkt) == 0)
+        return; // wait
+
+    struct mp_frame frame = {MP_FRAME_PACKET, pkt};
+    if (pkt) {
+        p->eof_returned = false;
+    } else {
+        frame.type = MP_FRAME_EOF;
+
+        // While the demuxer will repeat EOFs, filters never do that.
+        if (p->eof_returned)
+            return;
+        p->eof_returned = true;
+    }
+
+    mp_pin_in_write(f->ppins[0], frame);
+}
+
+static void reset(struct mp_filter *f)
+{
+    struct priv *p = f->priv;
+
+    p->eof_returned = false;
+}
+
+static void destroy(struct mp_filter *f)
+{
+    struct priv *p = f->priv;
+
+    demux_set_stream_wakeup_cb(p->src, NULL, NULL);
+}
+
+static const struct mp_filter_info demux_filter = {
+    .name = "demux",
+    .priv_size = sizeof(struct priv),
+    .process = process,
+    .reset = reset,
+    .destroy = destroy,
+};
+
+struct mp_filter *mp_demux_in_create(struct mp_filter *parent,
+                                     struct sh_stream *src)
+{
+    struct mp_filter *f = mp_filter_create(parent, &demux_filter);
+    if (!f)
+        return NULL;
+
+    struct priv *p = f->priv;
+    p->src = src;
+
+    mp_filter_add_pin(f, MP_PIN_OUT, "out");
+
+    demux_set_stream_wakeup_cb(p->src, wakeup, f);
+
+    return f;
+}