2002-01-02 Roland McGrath <roland@frob.com>
[kopensolaris-gnu/glibc.git] / hurd / hurdmsg.c
index 93929d1..ffcce61 100644 (file)
@@ -1,23 +1,28 @@
-/* Copyright (C) 1992, 1994 Free Software Foundation, Inc.
-This file is part of the GNU C Library.
+/* Copyright (C) 1992, 1994, 1995, 1996, 1997 Free Software Foundation, Inc.
+   This file is part of the GNU C Library.
 
-The GNU C Library is free software; you can redistribute it and/or
-modify it under the terms of the GNU Library General Public License as
-published by the Free Software Foundation; either version 2 of the
-License, or (at your option) any later version.
+   The GNU C Library is free software; you can redistribute it and/or
+   modify it under the terms of the GNU Lesser General Public
+   License as published by the Free Software Foundation; either
+   version 2.1 of the License, or (at your option) any later version.
 
-The GNU C Library 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
-Library General Public License for more details.
+   The GNU C Library 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
+   Lesser General Public License for more details.
 
-You should have received a copy of the GNU Library General Public
-License along with the GNU C Library; see the file COPYING.LIB.  If
-not, write to the Free Software Foundation, Inc., 675 Mass Ave,
-Cambridge, MA 02139, USA.  */
+   You should have received a copy of the GNU Lesser General Public
+   License along with the GNU C Library; if not, write to the Free
+   Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
+   02111-1307 USA.  */
 
 #include <hurd.h>
-#include "hurd/msg_server.h"
+#include <hurd/msg_server.h>
+#include <hurd/fd.h>
+#include <unistd.h>
+#include <limits.h>
+#include <string.h>
+#include <argz.h>
 
 
 #define AUTHCHECK \
@@ -27,34 +32,39 @@ Cambridge, MA 02139, USA.  */
 
 /* Snarfing and frobbing the init ports.  */
 
-error_t
-_S_get_init_port (mach_port_t msgport, mach_port_t auth,
-                 int which, mach_port_t *result)
+kern_return_t
+  _S_msg_get_init_port (mach_port_t msgport, mach_port_t auth, int which,
+                       mach_port_t *result, mach_msg_type_name_t *result_type)
 {
   AUTHCHECK;
+  *result_type = MACH_MSG_TYPE_MOVE_SEND;
   /* This function adds a new user reference for the *RESULT it gives back.
      Our reply message uses a move-send right that consumes this reference.  */
   return _hurd_ports_get (which, result);
 }
 
-error_t
-_S_set_init_port (mach_port_t msgport, mach_port_t auth,
-                 int which, mach_port_t port)
+kern_return_t
+_S_msg_set_init_port (mach_port_t msgport, mach_port_t auth,
+                     int which, mach_port_t port)
 {
+  error_t err;
+
   AUTHCHECK;
 
-  /* This function consumes a user reference for the PORT send right,
-     if it is successful.  */
-  return _hurd_ports_set (which, port);
+  err = _hurd_ports_set (which, port);
+  if (err == 0)
+    __mach_port_deallocate (__mach_task_self (), port);
+
+  return 0;
 }
 
-error_t
-_S_get_init_ports (mach_port_t msgport, mach_port_t auth,
-                  mach_port_t **ports,
-                  mach_msg_type_name_t *ports_type,
-                  unsigned int *nports)
+kern_return_t
+_S_msg_get_init_ports (mach_port_t msgport, mach_port_t auth,
+                      mach_port_t **ports,
+                      mach_msg_type_name_t *ports_type,
+                      mach_msg_type_number_t *nports)
 {
-  unsigned int i;
+  mach_msg_type_number_t i;
   error_t err;
 
   AUTHCHECK;
@@ -82,26 +92,29 @@ _S_get_init_ports (mach_port_t msgport, mach_port_t auth,
   return 0;
 }
 
-error_t
-_S_set_init_ports (mach_port_t msgport, mach_port_t auth,
-                  mach_port_t *ports, unsigned int nports)
+kern_return_t
+_S_msg_set_init_ports (mach_port_t msgport, mach_port_t auth,
+                      mach_port_t *ports, mach_msg_type_number_t nports)
 {
-  unsigned int i;
+  mach_msg_type_number_t i;
   error_t err;
 
   AUTHCHECK;
 
   for (i = 0; i < _hurd_nports; ++i)
-    /* This function consumes a user reference for the send right.  */
-    if (err = _hurd_ports_set (i, ports[i]))
-      return err;
+    {
+      if (err = _hurd_ports_set (i, ports[i]))
+       return err;
+      else
+       __mach_port_deallocate (__mach_task_self (), ports[i]);
+    }
 
   return 0;
 }
 \f
 /* Snarfing and frobbing the init ints.  */
 
-static error_t
+static kern_return_t
 get_int (int which, int *value)
 {
   switch (which)
@@ -111,28 +124,31 @@ get_int (int which, int *value)
       return 0;
     case INIT_SIGMASK:
       {
-       struct _hurd_sigstate *ss = _hurd_thread_sigstate (_hurd_sigthread);
+       struct hurd_sigstate *ss = _hurd_thread_sigstate (_hurd_sigthread);
+       __spin_lock (&ss->lock);
        *value = ss->blocked;
-       __mutex_unlock (&ss->lock);
+       __spin_unlock (&ss->lock);
        return 0;
       }
     case INIT_SIGPENDING:
       {
-       struct _hurd_sigstate *ss = _hurd_thread_sigstate (_hurd_sigthread);
+       struct hurd_sigstate *ss = _hurd_thread_sigstate (_hurd_sigthread);
+       __spin_lock (&ss->lock);
        *value = ss->pending;
-       __mutex_unlock (&ss->lock);
+       __spin_unlock (&ss->lock);
        return 0;
       }
     case INIT_SIGIGN:
       {
-       struct _hurd_sigstate *ss = _hurd_thread_sigstate (_hurd_sigthread);
+       struct hurd_sigstate *ss = _hurd_thread_sigstate (_hurd_sigthread);
        sigset_t ign;
        int sig;
+       __spin_lock (&ss->lock);
        __sigemptyset (&ign);
        for (sig = 1; sig < NSIG; ++sig)
          if (ss->actions[sig].sa_handler == SIG_IGN)
            __sigaddset (&ign, sig);
-       __mutex_unlock (&ss->lock);
+       __spin_unlock (&ss->lock);
        *value = ign;
        return 0;
       }
@@ -141,21 +157,21 @@ get_int (int which, int *value)
     }
 }
 
-error_t
-_S_get_init_int (mach_port_t msgport, mach_port_t auth,
-                int which, int *value)
+kern_return_t
+_S_msg_get_init_int (mach_port_t msgport, mach_port_t auth,
+                    int which, int *value)
 {
   AUTHCHECK;
 
   return get_int (which, value);
 }
 
-error_t
-_S_get_init_ints (mach_port_t msgport, mach_port_t auth,
-                 int **values, unsigned int *nvalues)
+kern_return_t
+_S_msg_get_init_ints (mach_port_t msgport, mach_port_t auth,
+                     int **values, mach_msg_type_number_t *nvalues)
 {
-  error_t;
-  unsigned int i;
+  error_t err;
+  mach_msg_type_number_t i;
 
   AUTHCHECK;
 
@@ -164,7 +180,7 @@ _S_get_init_ints (mach_port_t msgport, mach_port_t auth,
     return err;
   *nvalues = INIT_INT_MAX;
 
-  for (i = 0; i < INIT_INT_MAX)
+  for (i = 0; i < INIT_INT_MAX; ++i)
     switch (err = get_int (i, &(*values)[i]))
       {
       case 0:                  /* Success.  */
@@ -182,7 +198,7 @@ _S_get_init_ints (mach_port_t msgport, mach_port_t auth,
 }
 
 
-static error_t
+static kern_return_t
 set_int (int which, int value)
 {
   switch (which)
@@ -194,23 +210,26 @@ set_int (int which, int value)
       /* These are pretty odd things to do.  But you asked for it.  */
     case INIT_SIGMASK:
       {
-       struct _hurd_sigstate *ss = _hurd_thread_sigstate (_hurd_sigthread);
+       struct hurd_sigstate *ss = _hurd_thread_sigstate (_hurd_sigthread);
+       __spin_lock (&ss->lock);
        ss->blocked = value;
-       __mutex_unlock (&ss->lock);
+       __spin_unlock (&ss->lock);
        return 0;
       }
     case INIT_SIGPENDING:
       {
-       struct _hurd_sigstate *ss = _hurd_thread_sigstate (_hurd_sigthread);
+       struct hurd_sigstate *ss = _hurd_thread_sigstate (_hurd_sigthread);
+       __spin_lock (&ss->lock);
        ss->pending = value;
-       __mutex_unlock (&ss->lock);
+       __spin_unlock (&ss->lock);
        return 0;
       }
     case INIT_SIGIGN:
       {
-       struct _hurd_sigstate *ss = _hurd_thread_sigstate (_hurd_sigthread);
+       struct hurd_sigstate *ss = _hurd_thread_sigstate (_hurd_sigthread);
        int sig;
        const sigset_t ign = value;
+       __spin_lock (&ss->lock);
        for (sig = 1; sig < NSIG; ++sig)
          {
            if (__sigismember (&ign, sig))
@@ -218,7 +237,11 @@ set_int (int which, int value)
            else if (ss->actions[sig].sa_handler == SIG_IGN)
              ss->actions[sig].sa_handler = SIG_DFL;
          }
-       __mutex_unlock (&ss->lock);
+       __spin_unlock (&ss->lock);
+       return 0;
+
+      case INIT_TRACEMASK:
+       _hurdsig_traced = value;
        return 0;
       }
     default:
@@ -226,25 +249,25 @@ set_int (int which, int value)
     }
 }
 
-error_t
-_S_set_init_int (mach_port_t msgport, mach_port_t auth,
-                int which, int value)
+kern_return_t
+_S_msg_set_init_int (mach_port_t msgport, mach_port_t auth,
+                    int which, int value)
 {
   AUTHCHECK;
 
   return set_int (which, value);
 }
 
-error_t
-_S_set_init_ints (mach_port_t msgport, mach_port_t auth,
-                 const int *values, unsigned int nvalues)
+kern_return_t
+_S_msg_set_init_ints (mach_port_t msgport, mach_port_t auth,
+                     int *values, mach_msg_type_number_t nvalues)
 {
-  error_t;
-  unsigned int i;
+  error_t err;
+  mach_msg_type_number_t i;
 
   AUTHCHECK;
 
-  for (i = 0; i < INIT_INT_MAX)
+  for (i = 0; i < INIT_INT_MAX; ++i)
     switch (err = set_int (i, values[i]))
       {
       case 0:                  /* Success.  */
@@ -259,50 +282,66 @@ _S_set_init_ints (mach_port_t msgport, mach_port_t auth,
 }
 \f
 
-error_t
-_S_get_fd (mach_port_t msgport, mach_port_t auth,
-          int which, mach_port_t *result)
+kern_return_t
+_S_msg_get_fd (mach_port_t msgport, mach_port_t auth, int which,
+              mach_port_t *result, mach_msg_type_name_t *result_type)
 {
   AUTHCHECK;
 
+  /* This creates a new user reference for the send right.
+     Our reply message will move that reference to the caller.  */
   *result = __getdport (which);
   if (*result == MACH_PORT_NULL)
     return errno;
+  *result_type = MACH_MSG_TYPE_MOVE_SEND;
+
   return 0;
 }
 
-error_t
-_S_set_fd (mach_port_t msgport, mach_port_t auth,
-          int which, mach_port_t port)
+kern_return_t
+_S_msg_set_fd (mach_port_t msgport, mach_port_t auth,
+              int which, mach_port_t port)
 {
   AUTHCHECK;
 
+  /* We consume the reference if successful.  */
   return HURD_FD_USE (which, (_hurd_port2fd (descriptor, port, 0), 0));
 }
 \f
 /* Snarfing and frobbing environment variables.  */
 
-error_t
-_S_get_env_variable (mach_port_t msgport,
-                    const char *variable,
-                    char **data, unsigned int *datalen)
+kern_return_t
+_S_msg_get_env_variable (mach_port_t msgport,
+                        char *variable,
+                        char **data, mach_msg_type_number_t *datalen)
 {
+  error_t err;
+  mach_msg_type_number_t valuelen;
   const char *value = getenv (variable);
 
   if (value == NULL)
     return ENOENT;
 
-  *data = value;
-  *datalen = strlen (value);
+  valuelen = strlen (value);
+  if (valuelen > *datalen)
+    {
+      if (err = __vm_allocate (__mach_task_self (), 
+                              (vm_address_t *) data, valuelen, 1))
+       return err;
+    }
+
+  memcpy (*data, value, valuelen);
+  *datalen = valuelen;
+
   return 0;
 }
 
 
-error_t
-_S_set_env_variable (mach_port_t msgport, mach_port_t auth,
-                    const char *variable,
-                    char *value,
-                    int replace)
+kern_return_t
+_S_msg_set_env_variable (mach_port_t msgport, mach_port_t auth,
+                        char *variable,
+                        char *value,
+                        int replace)
 {
   AUTHCHECK;
 
@@ -311,40 +350,71 @@ _S_set_env_variable (mach_port_t msgport, mach_port_t auth,
   return 0;
 }
 
-error_t
-_S_get_environment (mach_port_t msgport,
-                   char **data, unsigned int *datalen)
+kern_return_t
+_S_msg_get_environment (mach_port_t msgport,
+                       char **data, mach_msg_type_number_t *datalen)
 {
-  int envc;
-  char **envp;
+  /* Pack the environment into an array with nulls separating elements.  */
+  if (__environ != NULL)
+    {
+      char *ap, **p;
+      size_t envlen = 0;
+
+      for (p = __environ; *p != NULL; ++p)
+       envlen += strlen (*p) + 1;
 
+      if (envlen > *datalen)
+       {
+         if (__vm_allocate (__mach_task_self (),
+                            (vm_address_t *) data, envlen, 1))
+           return ENOMEM;
+       }
+
+      ap = *data;
+      for (p = __environ; *p != NULL; ++p)
+       ap = __memccpy (ap, *p, '\0', ULONG_MAX);
+
+      *datalen = envlen;
+    }
+  else
+    *datalen = 0;
+
+  return 0;
 }
 
-error_t
-_S_set_environment (mach_port_t msgport, mach_port_t auth,
-                   char *data, unsigned int datalen)
+kern_return_t
+_S_msg_set_environment (mach_port_t msgport, mach_port_t auth,
+                       char *data, mach_msg_type_number_t datalen)
 {
+  int _hurd_split_args (char *, mach_msg_type_number_t, char **);
   int envc;
   char **envp;
 
   AUTHCHECK;
 
-  envc = _hurd_split_args (data, datalen, NULL);
+  envc = __argz_count (data, datalen);
   envp = malloc ((envc + 1) * sizeof (char *));
   if (envp == NULL)
     return errno;
-  _hurd_split_args (data, datalen, envc);
+  __argz_extract (data, datalen, envp);
   __environ = envp;            /* XXX cooperate with loadenv et al */
   return 0;
 }
-
 \f
 
 /* XXX */
-#define STUB(fn) error_t fn (mach_port_t port) { return EOPNOTSUPP; }
-
-STUB(_S_get_dtable)
-STUB(_S_set_dtable)
-STUB(_S_io_select_done)
-STUB(_S_startup_dosync)
 
+kern_return_t
+_S_msg_get_dtable (mach_port_t process,
+                  mach_port_t refport,
+                  portarray_t *dtable,
+                  mach_msg_type_name_t *dtablePoly,
+                  mach_msg_type_number_t *dtableCnt)
+{ return EOPNOTSUPP; }
+
+kern_return_t
+_S_msg_set_dtable (mach_port_t process,
+                  mach_port_t refport,
+                  portarray_t dtable,
+                  mach_msg_type_number_t dtableCnt)
+{ return EOPNOTSUPP; }