Subversion Repositories or1k

/*

 * Sun RPC is a product of Sun Microsystems, Inc. and is provided for

 * unrestricted use provided that this legend is included on all tape

 * media and as a part of the software program in whole or part.  Users

 * may copy or modify Sun RPC without charge, but are not authorized

 * to license or distribute it to anyone else except as part of a product or

 * program developed by the user.

 *

 * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE

 * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR

 * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE.

 *

 * Sun RPC is provided with no support and without any obligation on the

 * part of Sun Microsystems, Inc. to assist in its use, correction,

 * modification or enhancement.

 *

 * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE

 * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC

 * OR ANY PART THEREOF.

 *

 * In no event will Sun Microsystems, Inc. be liable for any lost revenue

 * or profits or other special, indirect and consequential damages, even if

 * Sun has been advised of the possibility of such damages.

 *

 * Sun Microsystems, Inc.

 * 2550 Garcia Avenue

 * Mountain View, California  94043

 */

/*

 * This is the rpc server side idle loop

 * Wait for input, call server program.

 */

#define __FORCE_GLIBC

#define _GNU_SOURCE

#include <features.h>

#include <errno.h>

#include <unistd.h>

#include <sys/poll.h>

#include <rpc/rpc.h>

/* This function can be used as a signal handler to terminate the

   server loop.  */

void

svc_exit (void)

{

  free (svc_pollfd);

  svc_pollfd = NULL;

  svc_max_pollfd = 0;

}

void

svc_run (void)

{

  int i;

  for (;;)

    {

      struct pollfd *my_pollfd;

      if (svc_max_pollfd == 0 && svc_pollfd == NULL)

        return;

      my_pollfd = malloc (sizeof (struct pollfd) * svc_max_pollfd);

      for (i = 0; i < svc_max_pollfd; ++i)

        {

          my_pollfd[i].fd = svc_pollfd[i].fd;

          my_pollfd[i].events = svc_pollfd[i].events;

          my_pollfd[i].revents = 0;

        }

      switch (i = poll (my_pollfd, svc_max_pollfd, -1))

        {

        case -1:

          free (my_pollfd);

          if (errno == EINTR)

            continue;

          perror (_("svc_run: - poll failed"));

          return;

        case 0:

          free (my_pollfd);

          continue;

        default:

          svc_getreq_poll (my_pollfd, i);

          free (my_pollfd);

        }

    }

}