summaryrefslogtreecommitdiffstats
path: root/input/pipe-unix.c
diff options
context:
space:
mode:
Diffstat (limited to 'input/pipe-unix.c')
-rw-r--r--input/pipe-unix.c59
1 files changed, 0 insertions, 59 deletions
diff --git a/input/pipe-unix.c b/input/pipe-unix.c
deleted file mode 100644
index 51eb315d6b..0000000000
--- a/input/pipe-unix.c
+++ /dev/null
@@ -1,59 +0,0 @@
-#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);
-}