home *** CD-ROM | disk | FTP | other *** search
/ Linux Cubed Series 4: GNU Archives / Linux Cubed Series 4 - GNU Archives.iso / gnu / glibc-1.09 / glibc-1 / glibc-1.09.1 / sysdeps / mach / hurd / __select.c < prev    next >
Encoding:
C/C++ Source or Header  |  1994-08-18  |  7.2 KB  |  242 lines
  1. /* Copyright (C) 1991, 1992, 1993, 1994 Free Software Foundation, Inc.
  2. This file is part of the GNU C Library.
  3.  
  4. The GNU C Library is free software; you can redistribute it and/or
  5. modify it under the terms of the GNU Library General Public License as
  6. published by the Free Software Foundation; either version 2 of the
  7. License, or (at your option) any later version.
  8.  
  9. The GNU C Library is distributed in the hope that it will be useful,
  10. but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12. Library General Public License for more details.
  13.  
  14. You should have received a copy of the GNU Library General Public
  15. License along with the GNU C Library; see the file COPYING.LIB.  If
  16. not, write to the Free Software Foundation, Inc., 675 Mass Ave,
  17. Cambridge, MA 02139, USA.  */
  18.  
  19. #include <ansidecl.h>
  20. #include <sys/types.h>
  21. #include <hurd.h>
  22. #include <hurd/fd.h>
  23. #include <stdlib.h>
  24. #include <gnu-stabs.h>
  25.  
  26. #define SELECT_DONE_MSGID 23020    /* XXX */
  27.  
  28. /* Check the first NFDS descriptors each in READFDS (if not NULL) for read
  29.    readiness, in WRITEFDS (if not NULL) for write readiness, and in EXCEPTFDS
  30.    (if not NULL) for exceptional conditions.  If TIMEOUT is not NULL, time out
  31.    after waiting the interval specified therein.  Returns the number of ready
  32.    descriptors, or -1 for errors.  */
  33. int
  34. DEFUN(__select, (nfds, readfds, writefds, exceptfds, timeout),
  35.       int nfds AND fd_set *readfds AND fd_set *writefds AND
  36.       fd_set *exceptfds AND struct timeval *timeout)
  37. {
  38.   int i;
  39.   mach_port_t port;
  40.   int got;
  41.   int *types;
  42.   struct hurd_userlink *ulink;
  43.   mach_port_t *ports;
  44.   struct hurd_fd **cells;
  45.   error_t err;
  46.  
  47.  
  48.   /* If we're going to bomb, do it before we acquire any locks.  */
  49.   if (readfds != NULL)
  50.     *(volatile fd_set *) readfds = *readfds;
  51.   if (writefds != NULL)
  52.     *(volatile fd_set *) writefds = *writefds;
  53.   if (exceptfds != NULL)
  54.     *(volatile fd_set *) exceptfds = *exceptfds;
  55.  
  56.   HURD_CRITICAL_BEGIN;
  57.   __mutex_lock (&_hurd_dtable_lock);
  58.  
  59.   if (nfds > _hurd_dtablesize)
  60.     nfds = _hurd_dtablesize;
  61.  
  62.   /* Collect the ports for interesting FDs.  */
  63.   cells = __alloca (nfds * sizeof (*cells));
  64.   ports = __alloca (nfds * sizeof (*ports));
  65.   types = __alloca (nfds * sizeof (*types));
  66.   ulink = __alloca (nfds * sizeof (*ulink));
  67.   for (i = 0; i < nfds; ++i)
  68.     {
  69.       int type = 0;
  70.       if (readfds != NULL && FD_ISSET (i, readfds))
  71.     type |= SELECT_READ;
  72.       if (writefds != NULL && FD_ISSET (i, writefds))
  73.     type |= SELECT_WRITE;
  74.       if (exceptfds != NULL && FD_ISSET (i, exceptfds))
  75.     type |= SELECT_URG;
  76.       types[i] = type;
  77.       if (type)
  78.     {
  79.       cells[i] = _hurd_dtable[i];
  80.       ports[i] = _hurd_port_get (&cells[i]->port, &ulink[i]);
  81.       if (ports[i] == MACH_PORT_NULL)
  82.         {
  83.           /* If one descriptor is bogus, we fail completely.  */
  84.           while (i-- > 0)
  85.         _hurd_port_free (&cells[i]->port, &ulink[i], ports[i]);
  86.           errno = EBADF;
  87.           break;
  88.         }
  89.     }
  90.     }
  91.  
  92.   __mutex_unlock (&_hurd_dtable_lock);
  93.   HURD_CRITICAL_END;
  94.  
  95.   if (i < nfds)
  96.     return -1;
  97.  
  98.   if (timeout != NULL && timeout->tv_sec == 0 && timeout->tv_usec == 0)
  99.     /* We just want to poll, so we don't need a receive right.  */
  100.     port = MACH_PORT_NULL;
  101.   else
  102.     /* Get a port to receive the io_select_done message on.  */
  103.     port = __mach_reply_port ();
  104.  
  105.   /* Send them all io_select calls.  */
  106.   got = 0;
  107.   err = 0;
  108.   for (i = 0; i < nfds; ++i)
  109.     if (types[i])
  110.       {
  111.     if (!err)
  112.       {
  113.         err = __io_select (ports[i], types[i],
  114.                    port, MACH_MSG_TYPE_MAKE_SEND_ONCE,
  115.                    i, &types[i]);
  116.         if (types[i])
  117.           ++got;
  118.       }
  119.     _hurd_port_free (&cells[i]->port, &ulink[i], ports[i]);
  120.       }
  121.  
  122.   /* If none were ready immediately, wait for a callback.  */
  123.   if (!err && got == 0 && port != MACH_PORT_NULL)
  124.     {
  125.       /* Now wait for select_done messages on PORT,
  126.      timing out as appropriate.  */
  127.  
  128.       union
  129.     {
  130.       mach_msg_header_t head;
  131.       struct
  132.         {
  133.           mach_msg_header_t head;
  134.           mach_msg_type_t result_type;
  135.           int result;
  136.           mach_msg_type_t tag_type;
  137.           int tag;
  138.         } request;
  139.       struct
  140.         {
  141.           mach_msg_header_t head;
  142.           mach_msg_type_t err_type;
  143.           error_t err;
  144.         } reply;
  145.     } msg;
  146.       const mach_msg_timeout_t to = (timeout != NULL ?
  147.                      (timeout->tv_sec * 1000 +
  148.                       timeout->tv_usec / 1000) :
  149.                      0);
  150.       mach_msg_option_t options = (timeout == NULL ? 0 : MACH_RCV_TIMEOUT);
  151.       while ((err = __mach_msg (&msg.head,
  152.                 MACH_RCV_MSG | options,
  153.                 sizeof (msg.reply), sizeof (msg.request),
  154.                 port, to, MACH_PORT_NULL)) == MACH_MSG_SUCCESS)
  155.     {
  156.       /* We got a message.  Decode it.  */
  157.       const mach_msg_type_t inttype =
  158.         { MACH_MSG_TYPE_INTEGER_32, 32, 1, 1, 0, 0 };
  159.       if (msg.head.msgh_id == SELECT_DONE_MSGID &&
  160.           !(msg.head.msgh_bits & MACH_MSGH_BITS_COMPLEX) &&
  161.           *(int *) &msg.request.result_type == *(int *) &inttype &&
  162.           *(int *) &msg.request.tag_type == *(int *) &inttype &&
  163.           (msg.request.result & (SELECT_READ|SELECT_WRITE|SELECT_URG)) &&
  164.           msg.request.tag >= 0 && msg.request.tag < nfds)
  165.         {
  166.           /* This is a winning io_select_done message!
  167.          Record the readiness it indicates and send a reply.  */
  168.  
  169.           if (types[msg.request.tag] == 0)
  170.         /* This descriptor is ready and it was not before,
  171.            so we increment our count of ready descriptors.  */
  172.         ++got;
  173.           types[msg.request.tag] |= msg.request.result;
  174.           if (msg.head.msgh_remote_port != MACH_PORT_NULL)
  175.         {
  176.           msg.head.msgh_id += 100;
  177.           msg.reply.err_type = inttype;
  178.           msg.reply.err = 0;
  179.           /* When we loop below, send this reply message in the
  180.              same operation that polls for another io_select_done
  181.              request message.  */
  182.           options |= MACH_SEND_MSG;
  183.           /* The reply message has no reply port of its own.  */
  184.           msg.head.msgh_bits &= ~MACH_MSGH_BITS_LOCAL_MASK;
  185.           msg.head.msgh_local_port = MACH_PORT_NULL;
  186.         }
  187.         }
  188.       else
  189.         {
  190.           /* Randomness.  */
  191.           __mach_msg_destroy (msg);
  192.           continue;
  193.         }
  194.  
  195.       /* Poll for another message.  */
  196.       timeout = 0;
  197.       options |= MACH_RCV_TIMEOUT;
  198.     }
  199.  
  200.     if (err == MACH_RCV_TIMED_OUT)
  201.       /* This is the normal value for ERR.  We might have timed out and
  202.          read no messages.  Otherwise, after receiving the first message,
  203.          we poll for more messages.  We receive with a timeout of 0 to
  204.          effect a poll, so ERR is MACH_RCV_TIMED_OUT when the poll finds no
  205.          message waiting.  */
  206.       err = 0;
  207.     }
  208.  
  209.   if (port != MACH_PORT_NULL)
  210.     /* We must destroy the port if we made some select requests
  211.        that might send notification on that port after we no longer care.
  212.        If the port were reused, that notification could confuse the next
  213.        select call to use the port.  The notification might be valid,
  214.        but the descriptor may have changed to a different server.  */
  215.     __mach_port_destroy (__mach_task_self (), port);
  216.  
  217.   if (err)
  218.     return __hurd_fail (err);
  219.  
  220.   /* Set the user bitarrays.  */
  221.   for (i = 0; i < nfds; ++i)
  222.     {
  223.       if (readfds != NULL)
  224.     if (types[i] & SELECT_READ)
  225.       FD_SET (i, readfds);
  226.     else
  227.       FD_CLR (i, readfds);
  228.       if (writefds != NULL)
  229.     if (types[i] & SELECT_WRITE)
  230.       FD_SET (i, writefds);
  231.     else
  232.       FD_CLR (i, writefds);
  233.       if (exceptfds != NULL)
  234.     if (types[i] & SELECT_URG)
  235.       FD_SET (i, exceptfds);
  236.     else
  237.       FD_CLR (i, exceptfds);
  238.     }
  239.  
  240.   return got;
  241. }
  242.