Initial revision

CVS patchset: 1
CVS date: 2001/04/18 22:33:39

1 files changed, 219 insertions, 0 deletions

diff --git a/src/input/input_stdin_fifo.c b/src/input/input_stdin_fifo.c
new file mode 100644
index 000000000..488564795
--- /dev/null
+++ b/src/input/input_stdin_fifo.c
@@ -0,0 +1,219 @@
+/* 
+ * Copyright (C) 2000-2001 the xine project
+ * 
+ * This file is part of xine, a unix video player.
+ * 
+ * xine is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ * 
+ * xine is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ * 
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA
+ *
+ * $Id: input_stdin_fifo.c,v 1.1 2001/04/18 22:34:05 f1rmb Exp $
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include <stdio.h>
+#include <string.h>
+#include <fcntl.h>
+#include <unistd.h>
+#include <sys/stat.h>
+#include <errno.h>
+
+#include "input_plugin.h"
+
+static uint32_t xine_debug;
+
+static int input_file_handle;
+
+/* ------------------------------------------------------------------------- */
+/*
+ *
+ */
+static void input_plugin_init(void) {
+
+  input_file_handle = -1;
+}
+/* ------------------------------------------------------------------------- */
+/*
+ *
+ */
+static int input_plugin_open(const char *mrl) {
+  char *filename;
+  char *pfn;
+
+  if(!strncasecmp(mrl, "stdin:", 6) 
+      || !strncmp(mrl, "-", 1)) {
+    filename = "/dev/stdin";
+  } 
+  else if(!strncasecmp(mrl, "fifo:", 5)) {
+
+    if((pfn = strrchr((mrl+5), ':')) != NULL) {
+      filename = ++pfn;
+    }
+    else {
+      filename = (char *) &mrl[5];
+    }
+
+  } 
+  else {
+    filename = (char *) mrl;
+  }
+  
+#ifdef DEBUG
+  fprintf(stderr, "%s(%d): opening >%s< file\n", 
+	  __FILE__, __LINE__, filename);
+#endif
+
+  input_file_handle = open(filename, O_RDONLY);
+
+  if(input_file_handle == -1) {
+    return 0;
+  }
+
+  return 1;
+}
+/* ------------------------------------------------------------------------- */
+/*
+ *
+ */
+static uint32_t input_plugin_read(char *buf, uint32_t nlen) {
+
+  int n, nBytesRead;
+
+  nBytesRead = 0;
+
+  while (nBytesRead < nlen) {
+    n = read(input_file_handle, &buf[nBytesRead], nlen-nBytesRead);
+
+    if (n<0)
+      return n;
+    else if (!n)
+      return nBytesRead;
+
+    nBytesRead += n;
+  }
+  return nBytesRead;
+}
+/* ------------------------------------------------------------------------- */
+/*
+ *
+ */
+static off_t input_plugin_seek(off_t offset, int origin) {
+
+  return lseek(input_file_handle, offset, origin);
+}
+/* ------------------------------------------------------------------------- */
+/*
+ *
+ */
+static off_t input_plugin_get_length(void) {
+  struct stat buf ;
+
+  if(fstat(input_file_handle, &buf) == 0) {
+    return buf.st_size;
+  } 
+  else { 
+    fprintf(stderr, "%s(%d): fstat() failed: %s\n",
+	    __FILE__, __LINE__, strerror(errno));
+  }
+
+  return 0;
+}
+/* ------------------------------------------------------------------------- */
+/*
+ *
+ */
+static uint32_t input_plugin_get_capabilities(void) {
+
+  return 0;
+}
+/* ------------------------------------------------------------------------- */
+/*
+ *
+ */
+static uint32_t input_plugin_get_blocksize(void) {
+
+  return 0;
+}
+/* ------------------------------------------------------------------------- */
+/*
+ *
+ */
+static int input_plugin_eject (void) {
+  return 1;
+}
+/* ------------------------------------------------------------------------- */
+/*
+ *
+ */
+static void input_plugin_close(void) {
+
+#ifdef DEBUG
+  fprintf(stderr, "%s(%d): closing input\n",
+	 __FILE__, __LINE__);
+#endif
+
+  close(input_file_handle);
+  input_file_handle = -1;
+}
+/* ------------------------------------------------------------------------- */
+/*
+ *
+ */
+static char *input_plugin_get_identifier(void) {
+
+  return "stdin_fifo";
+}
+/* ------------------------------------------------------------------------- */
+/*
+ *
+ */
+static int input_plugin_is_branch_possible (const char *next_mrl) {
+
+  return 0;
+}
+/* ------------------------------------------------------------------------- */
+/*
+ *
+ */
+static input_plugin_t plugin_op = {
+  NULL,
+  NULL,
+  input_plugin_init,
+  input_plugin_open,
+  input_plugin_read,
+  input_plugin_seek,
+  input_plugin_get_length,
+  input_plugin_get_capabilities,
+  NULL,
+  input_plugin_get_blocksize,
+  input_plugin_eject,
+  input_plugin_close,
+  input_plugin_get_identifier,
+  NULL,
+  input_plugin_is_branch_possible,
+  NULL
+};
+/* ------------------------------------------------------------------------- */
+/*
+ *
+ */
+input_plugin_t *input_plugin_getinfo(uint32_t dbglvl) {
+
+  xine_debug = dbglvl;
+
+  return &plugin_op;
+}
+/* ------------------------------------------------------------------------- */