1 files changed, 59 insertions, 0 deletions
diff --git a/input/pipe-unix.c b/input/pipe-unix.c
new file mode 100644
index 0000000000..51eb315d6b
--- /dev/null
+++ b/input/pipe-unix.c
@@ -0,0 +1,59 @@
+#include <stdio.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <unistd.h>
+
+#include <poll.h>
+
+#include "common/msg.h"
+#include "osdep/io.h"
+#include "input.h"
+#include "cmd_parse.h"
+
+static void read_pipe_thread(struct mp_input_src *src, void *param)
+{
+    void *tmp = talloc_new(NULL);
+    char *filename = talloc_strdup(tmp, param); // param deallocates after init
+    int wakeup_fd = mp_input_src_get_wakeup_fd(src);
+    int fd = -1;
+
+    struct mp_log *log = src->log;
+
+    int mode = O_RDONLY;
+    // Use RDWR for FIFOs to ensure they stay open over multiple accesses.
+    struct stat st;
+    if (stat(filename, &st) == 0 && S_ISFIFO(st.st_mode))
+        mode = O_RDWR;
+    fd = open(filename, mode);
+    if (fd < 0) {
+        mp_err(log, "Can't open %s.\n", filename);
+        goto done;
+    }
+
+    mp_input_src_init_done(src);
+
+    while (1) {
+        struct pollfd fds[2] = {
+            { .fd = fd, .events = POLLIN },
+            { .fd = wakeup_fd, .events = POLLIN },
+        };
+        poll(fds, 2, -1);
+        if (!(fds[0].revents & POLLIN))
+            break;
+        char buffer[128];
+        int r = read(fd, buffer, sizeof(buffer));
+        if (r <= 0)
+            break;
+        mp_input_src_feed_cmd_text(src, buffer, r);
+    }
+
+done:
+    close(fd);
+    talloc_free(tmp);
+}
+
+void mp_input_pipe_add(struct input_ctx *ictx, const char *filename)
+{
+    mp_input_add_thread_src(ictx, (void *)filename, read_pipe_thread);
+}