Initial revision

1 files changed, 152 insertions, 0 deletions

diff --git a/trans/bogus-fifo.c b/trans/bogus-fifo.c
new file mode 100644
index 00000000..bf57519d
--- /dev/null
+++ b/trans/bogus-fifo.c
@@ -0,0 +1,152 @@
+/* A translator for fifos
+
+   Copyright (C) 1995 Free Software Foundation, Inc.
+
+   Written by Miles Bader <miles@gnu.ai.mit.edu>
+
+   This program 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, or (at
+   your option) any later version.
+
+   This program 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., 675 Mass Ave, Cambridge, MA 02139, USA. */
+
+#include <hurd.h>
+#include <stdio.h>
+#include <error.h>
+#include <sys/socket.h>
+#include <hurd/paths.h>
+#include <hurd/socket.h>
+#include <hurd/fsys.h>
+#include "fsys_S.h"
+
+/* ---------------------------------------------------------------- */
+
+extern int fsys_server (mach_msg_header_t *, mach_msg_header_t *);
+
+/* The actual fifo, which is just a socket connected to itself.  */
+static socket_t fifo;
+
+void
+main (int argc, char **argv)
+{
+  error_t err;
+  char pflocal_name[1024];
+  mach_port_t pflocal;
+  mach_port_t bootstrap, fsys, realnode;
+  
+  if (argc != 1)
+    {
+      fprintf(stderr, "Usage: %s", program_invocation_name);
+      exit(-1);
+    }
+  
+  task_get_bootstrap_port (mach_task_self (), &bootstrap);
+  if (bootstrap == MACH_PORT_NULL)
+    error(3, 0, "Must be started as a translator");
+
+  /* Reply to our parent */
+  mach_port_allocate (mach_task_self (), MACH_PORT_RIGHT_RECEIVE, &fsys);
+  err = fsys_startup (bootstrap, fsys, MACH_MSG_TYPE_MAKE_SEND, &realnode);
+  if (err)
+    error(1, err, "starting translator");
+
+  /* Try and connect to the pflocal server */
+  sprintf (pflocal_name, "%s/%d", _SERVERS_SOCKET, PF_LOCAL);
+  pflocal = file_name_lookup (pflocal_name, 0, 0);
+  if (pflocal == MACH_PORT_NULL)
+    error (2, errno, "%s", pflocal_name);
+
+  /* Make a local domain socket to use for our data buffering.  */
+  err = socket_create (pflocal, SOCK_STREAM, 0, &fifo);
+  if (err)
+    error (3, err, "%s: socket_create", pflocal_name);
+
+  /* Connect the socket to itself, yielding a fifo!  */
+  err = socket_connect2 (fifo, fifo);
+  if (err)
+    error (3, err, "%s: socket_connect2", pflocal_name);
+
+  for (;;)
+    /* We don't ever time out.  The problem is, you only want to exit when
+       (1) the pipe is empty (which we can check), and (2) there are no other
+       users (which we can't).  If we just drop our ref to the pipe, there
+       still could be a writer holding a ref to it.  */
+    mach_msg_server_timeout (fsys_server, 0, fsys, MACH_RCV_TIMEOUT, 0);
+}
+
+/* ---------------------------------------------------------------- */
+
+error_t
+S_fsys_getroot (mach_port_t fsys, mach_port_t parent,
+		uid_t *uids, unsigned num_uids, gid_t *gids, unsigned num_gids,
+		int flags,
+		retry_type *do_retry, char *retry_name,
+		mach_port_t *result, mach_msg_type_name_t *result_type)
+{
+  /* Give back a handle on our fifo.  */
+  *do_retry = FS_RETRY_NORMAL;
+  *retry_name = '\0';
+  *result = fifo;
+  *result_type = MACH_MSG_TYPE_COPY_SEND;
+  return 0;
+}
+
+error_t
+S_fsys_startup (mach_port_t bootstrap, mach_port_t fsys,
+		mach_port_t *real, mach_msg_type_name_t *real_type)
+{
+  return EOPNOTSUPP;
+}
+
+error_t
+S_fsys_goaway (mach_port_t fsys, int flags)
+{
+  /* If there are refs to the fifo left besides ours, it will
+     stay around after we're gone.  */
+  exit (0);
+}
+
+error_t
+S_fsys_syncfs (mach_port_t fsys, int wait, int recurse)
+{
+  return 0;
+}
+
+error_t
+S_fsys_set_options (mach_port_t fsys,
+		    char *data, mach_msg_type_number_t data_len, int recurse)
+{
+  return EOPNOTSUPP;
+}
+
+error_t
+S_fsys_getfile (mach_port_t fsys,
+		uid_t *uids, unsigned num_uids, gid_t *gids, unsigned num_gids,
+		char *handle, unsigned handle_len,
+		mach_port_t *port, mach_msg_type_name_t *port_type)
+{
+  return EOPNOTSUPP;
+}
+
+error_t
+S_fsys_getpriv (mach_port_t fsys,
+		mach_port_t *hostpriv, mach_port_t *devmaster, task_t *fstask)
+{
+  return EOPNOTSUPP;
+}
+
+error_t
+S_fsys_init (mach_port_t fsys,
+	     mach_port_t reply, mach_msg_type_name_t reply_type,
+	     mach_port_t proc, auth_t auth)
+{
+  return EOPNOTSUPP;
+}