1 files changed, 148 insertions, 0 deletions
diff --git a/cpukit/libfs/src/imfs/imfs_fifo.c b/cpukit/libfs/src/imfs/imfs_fifo.c
new file mode 100644
index 0000000000..7cb3bbcd85
--- /dev/null
+++ b/cpukit/libfs/src/imfs/imfs_fifo.c
@@ -0,0 +1,148 @@
+/*
+ * imfs_fifo.c: FIFO support for IMFS
+ *
+ * Author: Wei Shen <cquark@gmail.com>
+ *
+ * The license and distribution terms for this file may be
+ * found in the file LICENSE in this distribution or at
+ * http://www.rtems.com/license/LICENSE.
+ *
+ * $Id$
+ */
+
+#if HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include <stdlib.h>
+#include <rtems/libio_.h>
+#include <rtems/seterr.h>
+
+#include "imfs.h"
+
+#define JNODE2PIPE(_jnode)  ( (_jnode)->info.fifo.pipe )
+
+#define LIBIO2PIPE(_iop)  ( JNODE2PIPE((IMFS_jnode_t *)(_iop)->pathinfo.node_access) )
+
+/* Set errno and return -1 if error, else return _err */
+#define IMFS_FIFO_RETURN(_err) \
+do {  \
+  if (_err < 0)	\
+    rtems_set_errno_and_return_minus_one(-_err); \
+  return _err; \
+} while (0)
+
+int IMFS_fifo_open(
+  rtems_libio_t *iop,
+  const char    *pathname,
+  uint32_t       flag,
+  uint32_t       mode
+)
+{
+  IMFS_jnode_t *jnode = iop->pathinfo.node_access;
+
+  int err = fifo_open(&JNODE2PIPE(jnode), iop);
+  IMFS_FIFO_RETURN(err);
+}
+
+int IMFS_fifo_close(
+  rtems_libio_t *iop
+)
+{
+  int err = 0;
+  IMFS_jnode_t *jnode = iop->pathinfo.node_access;
+
+  pipe_release(&JNODE2PIPE(jnode), iop);
+
+  iop->flags &= ~LIBIO_FLAGS_OPEN;
+  IMFS_check_node_remove(jnode);
+  
+  IMFS_FIFO_RETURN(err);
+}
+
+ssize_t IMFS_fifo_read(
+  rtems_libio_t *iop,
+  void          *buffer,
+  size_t         count
+)
+{
+  IMFS_jnode_t *jnode = iop->pathinfo.node_access;
+
+  int err = pipe_read(JNODE2PIPE(jnode), buffer, count, iop);
+  if (err > 0)
+    IMFS_update_atime(jnode);
+
+  IMFS_FIFO_RETURN(err);
+}
+
+ssize_t IMFS_fifo_write(
+  rtems_libio_t *iop,
+  const void    *buffer,
+  size_t         count
+)
+{
+  IMFS_jnode_t *jnode = iop->pathinfo.node_access;
+
+  int err = pipe_write(JNODE2PIPE(jnode), buffer, count, iop);
+  if (err > 0) {
+    IMFS_mtime_ctime_update(jnode);
+  }
+
+  IMFS_FIFO_RETURN(err);
+}
+
+int IMFS_fifo_ioctl(
+  rtems_libio_t *iop,
+  uint32_t       command,
+  void          *buffer
+)
+{
+  int err;
+
+  if (command == FIONBIO) {
+    if (buffer == NULL)
+      err = -EFAULT;
+    else {
+      if (*(int *)buffer)
+        iop->flags |= LIBIO_FLAGS_NO_DELAY;
+      else
+        iop->flags &= ~LIBIO_FLAGS_NO_DELAY;
+      return 0;
+    }
+  }
+  else
+    err = pipe_ioctl(LIBIO2PIPE(iop), command, buffer, iop);
+
+  IMFS_FIFO_RETURN(err);
+}
+
+rtems_off64_t IMFS_fifo_lseek(
+  rtems_libio_t *iop,
+  rtems_off64_t  offset,
+  int            whence
+)
+{
+  off_t err = pipe_lseek(LIBIO2PIPE(iop), offset, whence, iop);
+  IMFS_FIFO_RETURN(err);
+}
+
+/*
+ *  Handler table for IMFS FIFO nodes
+ */
+
+const rtems_filesystem_file_handlers_r IMFS_fifo_handlers = {
+  IMFS_fifo_open,
+  IMFS_fifo_close,
+  IMFS_fifo_read,
+  IMFS_fifo_write,
+  IMFS_fifo_ioctl,
+  IMFS_fifo_lseek,
+  IMFS_stat,
+  IMFS_fchmod,
+  rtems_filesystem_default_ftruncate,
+  rtems_filesystem_default_fpathconf,
+  rtems_filesystem_default_fsync,
+  rtems_filesystem_default_fdatasync,
+  rtems_filesystem_default_fcntl,
+  IMFS_rmnod,
+};