Fix prototypes and parameters for compiling with enabled warnings.
authordrepper <drepper>
Thu, 27 Mar 1997 01:50:03 +0000 (01:50 +0000)
committerdrepper <drepper>
Thu, 27 Mar 1997 01:50:03 +0000 (01:50 +0000)
sunrpc/get_myaddr.c
sunrpc/getrpcport.c
sunrpc/pm_getmaps.c
sunrpc/pm_getport.c
sunrpc/pmap_clnt.c
sunrpc/pmap_prot.c
sunrpc/pmap_prot2.c
sunrpc/pmap_rmt.c
sunrpc/rpc_clntout.c

index c0ff44e..d45cb6d 100644 (file)
@@ -38,6 +38,7 @@ static char sccsid[] = "@(#)get_myaddress.c 1.4 87/08/11 Copyr 1984 Sun Micro";
  * Copyright (C) 1984, Sun Microsystems, Inc.
  */
 
+#include <unistd.h>
 #include <rpc/types.h>
 #include <rpc/pmap_prot.h>
 #include <sys/socket.h>
@@ -53,40 +54,44 @@ static char sccsid[] = "@(#)get_myaddress.c 1.4 87/08/11 Copyr 1984 Sun Micro";
 /*
  * don't use gethostbyname, which would invoke yellow pages
  */
-get_myaddress(addr)
-       struct sockaddr_in *addr;
+void
+get_myaddress (struct sockaddr_in *addr)
 {
-       int s;
-       char buf[BUFSIZ];
-       struct ifconf ifc;
-       struct ifreq ifreq, *ifr;
-       int len;
+  int s;
+  char buf[BUFSIZ];
+  struct ifconf ifc;
+  struct ifreq ifreq, *ifr;
+  int len;
 
-       if ((s = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
-           perror("get_myaddress: socket");
-           exit(1);
+  if ((s = socket (AF_INET, SOCK_DGRAM, 0)) < 0)
+    {
+      perror ("get_myaddress: socket");
+      exit (1);
+    }
+  ifc.ifc_len = sizeof (buf);
+  ifc.ifc_buf = buf;
+  if (ioctl (s, SIOCGIFCONF, (char *) &ifc) < 0)
+    {
+      perror (_("get_myaddress: ioctl (get interface configuration)"));
+      exit (1);
+    }
+  ifr = ifc.ifc_req;
+  for (len = ifc.ifc_len; len; len -= sizeof ifreq)
+    {
+      ifreq = *ifr;
+      if (ioctl (s, SIOCGIFFLAGS, (char *) &ifreq) < 0)
+       {
+         perror ("get_myaddress: ioctl");
+         exit (1);
        }
-       ifc.ifc_len = sizeof (buf);
-       ifc.ifc_buf = buf;
-       if (ioctl(s, SIOCGIFCONF, (char *)&ifc) < 0) {
-               perror(
-                  _("get_myaddress: ioctl (get interface configuration)"));
-               exit(1);
+      if ((ifreq.ifr_flags & IFF_UP) &&
+         ifr->ifr_addr.sa_family == AF_INET)
+       {
+         *addr = *((struct sockaddr_in *) &ifr->ifr_addr);
+         addr->sin_port = htons (PMAPPORT);
+         break;
        }
-       ifr = ifc.ifc_req;
-       for (len = ifc.ifc_len; len; len -= sizeof ifreq) {
-               ifreq = *ifr;
-               if (ioctl(s, SIOCGIFFLAGS, (char *)&ifreq) < 0) {
-                       perror("get_myaddress: ioctl");
-                       exit(1);
-               }
-               if ((ifreq.ifr_flags & IFF_UP) &&
-                   ifr->ifr_addr.sa_family == AF_INET) {
-                       *addr = *((struct sockaddr_in *)&ifr->ifr_addr);
-                       addr->sin_port = htons(PMAPPORT);
-                       break;
-               }
-               ifr++;
-       }
-       (void) close(s);
+      ifr++;
+    }
+  (void) close (s);
 }
index 3e94dbb..df48dc6 100644 (file)
@@ -38,35 +38,37 @@ static  char sccsid[] = "@(#)getrpcport.c 1.3 87/08/11 SMI";
 #include <alloca.h>
 #include <errno.h>
 #include <stdio.h>
-#include <rpc/rpc.h>
 #include <netdb.h>
+#include <string.h>
+#include <rpc/rpc.h>
+#include <rpc/clnt.h>
+#include <rpc/pmap_clnt.h>
 #include <sys/socket.h>
 
 int
-getrpcport(host, prognum, versnum, proto)
-       char *host;
+getrpcport (const char *host, u_long prognum, u_long versnum, u_int proto)
 {
-       struct sockaddr_in addr;
-       struct hostent hostbuf, *hp;
-       size_t buflen;
-       char *buffer;
-       int herr;
+  struct sockaddr_in addr;
+  struct hostent hostbuf, *hp;
+  size_t buflen;
+  char *buffer;
+  int herr;
 
-       buflen = 1024;
+  buflen = 1024;
+  buffer = __alloca (buflen);
+  while (__gethostbyname_r (host, &hostbuf, buffer, buflen, &hp, &herr)
+        < 0)
+    if (herr != NETDB_INTERNAL || errno != ERANGE)
+      return 0;
+    else
+      {
+       /* Enlarge the buffer.  */
+       buflen *= 2;
        buffer = __alloca (buflen);
-       while (__gethostbyname_r (host, &hostbuf, buffer, buflen, &hp, &herr)
-              < 0)
-         if (herr != NETDB_INTERNAL || errno != ERANGE)
-           return 0;
-         else
-           {
-             /* Enlarge the buffer.  */
-             buflen *= 2;
-             buffer = __alloca (buflen);
-           }
+      }
 
-       bcopy(hp->h_addr, (char *) &addr.sin_addr, hp->h_length);
-       addr.sin_family = AF_INET;
-       addr.sin_port =  0;
-       return (pmap_getport(&addr, prognum, versnum, proto));
+  bcopy (hp->h_addr, (char *) &addr.sin_addr, hp->h_length);
+  addr.sin_family = AF_INET;
+  addr.sin_port = 0;
+  return pmap_getport (&addr, prognum, versnum, proto);
 }
index d84e0c5..2812b3a 100644 (file)
@@ -47,43 +47,34 @@ static char sccsid[] = "@(#)pmap_getmaps.c 1.10 87/08/11 Copyr 1984 Sun Micro";
 #include <stdio.h>
 #include <errno.h>
 
-#if 0  /* these seem to be gratuitous --roland@gnu */
-#include <net/if.h>
-#include <sys/ioctl.h>
-#define NAMELEN 255
-#define MAX_BROADCAST_SIZE 1400
-#endif
-
-#ifndef errno
-extern int errno;
-#endif
-
 /*
  * Get a copy of the current port maps.
  * Calls the pmap service remotely to do get the maps.
  */
 struct pmaplist *
-pmap_getmaps(address)
-        struct sockaddr_in *address;
+pmap_getmaps (struct sockaddr_in *address)
 {
-       struct pmaplist *head = (struct pmaplist *)NULL;
-       int socket = -1;
-       struct timeval minutetimeout;
-       register CLIENT *client;
+  struct pmaplist *head = (struct pmaplist *) NULL;
+  int socket = -1;
+  struct timeval minutetimeout;
+  CLIENT *client;
 
-       minutetimeout.tv_sec = 60;
-       minutetimeout.tv_usec = 0;
-       address->sin_port = htons(PMAPPORT);
-       client = clnttcp_create(address, PMAPPROG,
-           PMAPVERS, &socket, 50, 500);
-       if (client != (CLIENT *)NULL) {
-               if (CLNT_CALL(client, PMAPPROC_DUMP, xdr_void, NULL, xdr_pmaplist,
-                   &head, minutetimeout) != RPC_SUCCESS) {
-                       clnt_perror(client, "pmap_getmaps rpc problem");
-               }
-               CLNT_DESTROY(client);
+  minutetimeout.tv_sec = 60;
+  minutetimeout.tv_usec = 0;
+  address->sin_port = htons (PMAPPORT);
+  client = clnttcp_create (address, PMAPPROG,
+                          PMAPVERS, &socket, 50, 500);
+  if (client != (CLIENT *) NULL)
+    {
+      if (CLNT_CALL (client, PMAPPROC_DUMP, (xdrproc_t)xdr_void, NULL,
+                    (xdrproc_t)xdr_pmaplist, (caddr_t)&head,
+                    minutetimeout) != RPC_SUCCESS)
+       {
+         clnt_perror (client, _("pmap_getmaps rpc problem"));
        }
-       /* (void)close(socket); CLNT_DESTROY already closed it */
-       address->sin_port = 0;
-       return (head);
+      CLNT_DESTROY (client);
+    }
+  /* (void)close(socket); CLNT_DESTROY already closed it */
+  address->sin_port = 0;
+  return head;
 }
index f156af4..be3cb49 100644 (file)
@@ -43,12 +43,10 @@ static char sccsid[] = "@(#)pmap_getport.c 1.9 87/08/11 Copyr 1984 Sun Micro";
 #include <rpc/pmap_clnt.h>
 #include <sys/socket.h>
 
-#if 0  /* these seem to be gratuitous --roland@gnu */
-#include <net/if.h>
-#endif
-
-static struct timeval timeout = { 5, 0 };
-static struct timeval tottimeout = { 60, 0 };
+static const struct timeval timeout =
+{5, 0};
+static const struct timeval tottimeout =
+{60, 0};
 
 /*
  * Find the mapped port for program,version.
@@ -56,35 +54,40 @@ static struct timeval tottimeout = { 60, 0 };
  * Returns 0 if no map exists.
  */
 u_short
-pmap_getport(address, program, version, protocol)
-       struct sockaddr_in *address;
-       u_long program;
-       u_long version;
-       u_int protocol;
+pmap_getport (address, program, version, protocol)
+     struct sockaddr_in *address;
+     u_long program;
+     u_long version;
+     u_int protocol;
 {
-       u_short port = 0;
-       int socket = -1;
-       register CLIENT *client;
-       struct pmap parms;
+  u_short port = 0;
+  int socket = -1;
+  CLIENT *client;
+  struct pmap parms;
 
-       address->sin_port = htons(PMAPPORT);
-       client = clntudp_bufcreate(address, PMAPPROG,
-           PMAPVERS, timeout, &socket, RPCSMALLMSGSIZE, RPCSMALLMSGSIZE);
-       if (client != (CLIENT *)NULL) {
-               parms.pm_prog = program;
-               parms.pm_vers = version;
-               parms.pm_prot = protocol;
-               parms.pm_port = 0;  /* not needed or used */
-               if (CLNT_CALL(client, PMAPPROC_GETPORT, xdr_pmap, &parms,
-                   xdr_u_short, &port, tottimeout) != RPC_SUCCESS){
-                       rpc_createerr.cf_stat = RPC_PMAPFAILURE;
-                       clnt_geterr(client, &rpc_createerr.cf_error);
-               } else if (port == 0) {
-                       rpc_createerr.cf_stat = RPC_PROGNOTREGISTERED;
-               }
-               CLNT_DESTROY(client);
+  address->sin_port = htons (PMAPPORT);
+  client = clntudp_bufcreate (address, PMAPPROG,
+             PMAPVERS, timeout, &socket, RPCSMALLMSGSIZE, RPCSMALLMSGSIZE);
+  if (client != (CLIENT *) NULL)
+    {
+      parms.pm_prog = program;
+      parms.pm_vers = version;
+      parms.pm_prot = protocol;
+      parms.pm_port = 0;       /* not needed or used */
+      if (CLNT_CALL (client, PMAPPROC_GETPORT, (xdrproc_t)xdr_pmap,
+                    (caddr_t)&parms, (xdrproc_t)xdr_u_short,
+                    (caddr_t)&port, tottimeout) != RPC_SUCCESS)
+       {
+         rpc_createerr.cf_stat = RPC_PMAPFAILURE;
+         clnt_geterr (client, &rpc_createerr.cf_error);
+       }
+      else if (port == 0)
+       {
+         rpc_createerr.cf_stat = RPC_PROGNOTREGISTERED;
        }
-       /* (void)close(socket); CLNT_DESTROY already closed it */
-       address->sin_port = 0;
-       return (port);
+      CLNT_DESTROY (client);
+    }
+  /* (void)close(socket); CLNT_DESTROY already closed it */
+  address->sin_port = 0;
+  return port;
 }
index 08285e2..263cd13 100644 (file)
@@ -42,46 +42,43 @@ static char sccsid[] = "@(#)pmap_clnt.c 1.37 87/08/11 Copyr 1984 Sun Micro";
 #include <rpc/pmap_prot.h>
 #include <rpc/pmap_clnt.h>
 
-static struct timeval timeout = { 5, 0 };
-static struct timeval tottimeout = { 60, 0 };
-
-void clnt_perror();
+extern void get_myaddress (struct sockaddr_in *addr);
 
+static const struct timeval timeout = {5, 0};
+static const struct timeval tottimeout = {60, 0};
 
 /*
  * Set a mapping between program,version and port.
  * Calls the pmap service remotely to do the mapping.
  */
 bool_t
-pmap_set(program, version, protocol, port)
-       u_long program;
-       u_long version;
-       int protocol;
-       u_short port;
+pmap_set (u_long program, u_long version, int protocol, u_short port)
 {
-       struct sockaddr_in myaddress;
-       int socket = -1;
-       register CLIENT *client;
-       struct pmap parms;
-       bool_t rslt;
+  struct sockaddr_in myaddress;
+  int socket = -1;
+  CLIENT *client;
+  struct pmap parms;
+  bool_t rslt;
 
-       get_myaddress(&myaddress);
-       client = clntudp_bufcreate(&myaddress, PMAPPROG, PMAPVERS,
-           timeout, &socket, RPCSMALLMSGSIZE, RPCSMALLMSGSIZE);
-       if (client == (CLIENT *)NULL)
-               return (FALSE);
-       parms.pm_prog = program;
-       parms.pm_vers = version;
-       parms.pm_prot = protocol;
-       parms.pm_port = port;
-       if (CLNT_CALL(client, PMAPPROC_SET, xdr_pmap, &parms, xdr_bool, &rslt,
-           tottimeout) != RPC_SUCCESS) {
-               clnt_perror(client, _("Cannot register service"));
-               return (FALSE);
-       }
-       CLNT_DESTROY(client);
-       /* (void)close(socket); CLNT_DESTROY closes it */
-       return (rslt);
+  get_myaddress (&myaddress);
+  client = clntudp_bufcreate (&myaddress, PMAPPROG, PMAPVERS,
+                       timeout, &socket, RPCSMALLMSGSIZE, RPCSMALLMSGSIZE);
+  if (client == (CLIENT *) NULL)
+    return (FALSE);
+  parms.pm_prog = program;
+  parms.pm_vers = version;
+  parms.pm_prot = protocol;
+  parms.pm_port = port;
+  if (CLNT_CALL (client, PMAPPROC_SET, (xdrproc_t)xdr_pmap, (caddr_t)&parms,
+                (xdrproc_t)xdr_bool, (caddr_t)&rslt,
+                tottimeout) != RPC_SUCCESS)
+    {
+      clnt_perror (client, _("Cannot register service"));
+      return FALSE;
+    }
+  CLNT_DESTROY (client);
+  /* (void)close(socket); CLNT_DESTROY closes it */
+  return rslt;
 }
 
 /*
@@ -89,27 +86,25 @@ pmap_set(program, version, protocol, port)
  * Calls the pmap service remotely to do the un-mapping.
  */
 bool_t
-pmap_unset(program, version)
-       u_long program;
-       u_long version;
+pmap_unset (u_long program, u_long version)
 {
-       struct sockaddr_in myaddress;
-       int socket = -1;
-       register CLIENT *client;
-       struct pmap parms;
-       bool_t rslt;
+  struct sockaddr_in myaddress;
+  int socket = -1;
+  CLIENT *client;
+  struct pmap parms;
+  bool_t rslt;
 
-       get_myaddress(&myaddress);
-       client = clntudp_bufcreate(&myaddress, PMAPPROG, PMAPVERS,
-           timeout, &socket, RPCSMALLMSGSIZE, RPCSMALLMSGSIZE);
-       if (client == (CLIENT *)NULL)
-               return (FALSE);
-       parms.pm_prog = program;
-       parms.pm_vers = version;
-       parms.pm_port = parms.pm_prot = 0;
-       CLNT_CALL(client, PMAPPROC_UNSET, xdr_pmap, &parms, xdr_bool, &rslt,
-           tottimeout);
-       CLNT_DESTROY(client);
-       /* (void)close(socket); CLNT_DESTROY already closed it */
-       return (rslt);
+  get_myaddress (&myaddress);
+  client = clntudp_bufcreate (&myaddress, PMAPPROG, PMAPVERS,
+                       timeout, &socket, RPCSMALLMSGSIZE, RPCSMALLMSGSIZE);
+  if (client == (CLIENT *) NULL)
+    return FALSE;
+  parms.pm_prog = program;
+  parms.pm_vers = version;
+  parms.pm_port = parms.pm_prot = 0;
+  CLNT_CALL (client, PMAPPROC_UNSET, (xdrproc_t)xdr_pmap, (caddr_t)&parms,
+            (xdrproc_t)xdr_bool, (caddr_t)&rslt, tottimeout);
+  CLNT_DESTROY (client);
+  /* (void)close(socket); CLNT_DESTROY already closed it */
+  return rslt;
 }
index 643c2ff..9829718 100644 (file)
@@ -6,23 +6,23 @@
  * 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
@@ -44,14 +44,14 @@ static char sccsid[] = "@(#)pmap_prot.c 1.17 87/08/11 Copyr 1984 Sun Micro";
 
 
 bool_t
-xdr_pmap(xdrs, regs)
-       XDR *xdrs;
-       struct pmap *regs;
+xdr_pmap (xdrs, regs)
+     XDR *xdrs;
+     struct pmap *regs;
 {
 
-       if (xdr_u_long(xdrs, &regs->pm_prog) && 
-               xdr_u_long(xdrs, &regs->pm_vers) && 
-               xdr_u_long(xdrs, &regs->pm_prot))
-               return (xdr_u_long(xdrs, &regs->pm_port));
-       return (FALSE);
+  if (xdr_u_long (xdrs, &regs->pm_prog) &&
+      xdr_u_long (xdrs, &regs->pm_vers) &&
+      xdr_u_long (xdrs, &regs->pm_prot))
+    return xdr_u_long (xdrs, &regs->pm_port);
+  return FALSE;
 }
index e2a8214..6cb7c5e 100644 (file)
@@ -6,23 +6,23 @@
  * 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
@@ -43,34 +43,34 @@ static char sccsid[] = "@(#)pmap_prot2.c 1.3 87/08/11 Copyr 1984 Sun Micro";
 #include <rpc/pmap_prot.h>
 
 
-/* 
+/*
  * What is going on with linked lists? (!)
  * First recall the link list declaration from pmap_prot.h:
  *
  * struct pmaplist {
- *     struct pmap pml_map;
- *     struct pmaplist *pml_map;
+ *      struct pmap pml_map;
+ *      struct pmaplist *pml_map;
  * };
  *
- * Compare that declaration with a corresponding xdr declaration that 
+ * Compare that declaration with a corresponding xdr declaration that
  * is (a) pointer-less, and (b) recursive:
  *
  * typedef union switch (bool_t) {
- * 
- *     case TRUE: struct {
- *             struct pmap;
- *             pmaplist_t foo;
- *     };
  *
- *     case FALSE: struct {};
+ *      case TRUE: struct {
+ *              struct pmap;
+ *              pmaplist_t foo;
+ *      };
+ *
+ *      case FALSE: struct {};
  * } pmaplist_t;
  *
  * Notice that the xdr declaration has no nxt pointer while
  * the C declaration has no bool_t variable.  The bool_t can be
  * interpreted as ``more data follows me''; if FALSE then nothing
  * follows this bool_t; if TRUE then the bool_t is followed by
- * an actual struct pmap, and then (recursively) by the 
- * xdr union, pamplist_t.  
+ * an actual struct pmap, and then (recursively) by the
+ * xdr union, pamplist_t.
  *
  * This could be implemented via the xdr_union primitive, though this
  * would cause a one recursive call per element in the list.  Rather than do
@@ -82,35 +82,37 @@ static char sccsid[] = "@(#)pmap_prot2.c 1.3 87/08/11 Copyr 1984 Sun Micro";
  * this sounds like a job for xdr_reference!
  */
 bool_t
-xdr_pmaplist(xdrs, rp)
-       register XDR *xdrs;
-       register struct pmaplist **rp;
+xdr_pmaplist (xdrs, rp)
+     XDR *xdrs;
+     struct pmaplist **rp;
 {
-       /*
-        * more_elements is pre-computed in case the direction is
-        * XDR_ENCODE or XDR_FREE.  more_elements is overwritten by
-        * xdr_bool when the direction is XDR_DECODE.
-        */
-       bool_t more_elements;
-       register int freeing = (xdrs->x_op == XDR_FREE);
-       register struct pmaplist **next;
+  /*
+   * more_elements is pre-computed in case the direction is
+   * XDR_ENCODE or XDR_FREE.  more_elements is overwritten by
+   * xdr_bool when the direction is XDR_DECODE.
+   */
+  bool_t more_elements;
+  int freeing = (xdrs->x_op == XDR_FREE);
+  struct pmaplist **next = NULL;
 
-       while (TRUE) {
-               more_elements = (bool_t)(*rp != NULL);
-               if (! xdr_bool(xdrs, &more_elements))
-                       return (FALSE);
-               if (! more_elements)
-                       return (TRUE);  /* we are done */
-               /*
-                * the unfortunate side effect of non-recursion is that in
-                * the case of freeing we must remember the next object
-                * before we free the current object ...
-                */
-               if (freeing)
-                       next = &((*rp)->pml_next); 
-               if (! xdr_reference(xdrs, (caddr_t *)rp,
-                   (u_int)sizeof(struct pmaplist), xdr_pmap))
-                       return (FALSE);
-               rp = (freeing) ? next : &((*rp)->pml_next);
-       }
+  while (TRUE)
+    {
+      more_elements = (bool_t) (*rp != NULL);
+      if (!xdr_bool (xdrs, &more_elements))
+       return FALSE;
+      if (!more_elements)
+       return TRUE;            /* we are done */
+      /*
+       * the unfortunate side effect of non-recursion is that in
+       * the case of freeing we must remember the next object
+       * before we free the current object ...
+       */
+      if (freeing)
+       next = &((*rp)->pml_next);
+      if (!xdr_reference (xdrs, (caddr_t *) rp,
+                         (u_int) sizeof (struct pmaplist),
+                         (xdrproc_t) xdr_pmap))
+         return FALSE;
+      rp = freeing ? next : &((*rp)->pml_next);
+    }
 }
index 8907929..c3667d4 100644 (file)
@@ -39,6 +39,8 @@ static char sccsid[] = "@(#)pmap_rmt.c 1.21 87/08/27 Copyr 1984 Sun Micro";
  * Copyright (C) 1984, Sun Microsystems, Inc.
  */
 
+#include <unistd.h>
+#include <string.h>
 #include <rpc/rpc.h>
 #include <rpc/pmap_prot.h>
 #include <rpc/pmap_clnt.h>
@@ -53,11 +55,7 @@ static char sccsid[] = "@(#)pmap_rmt.c 1.21 87/08/27 Copyr 1984 Sun Micro";
 #include <arpa/inet.h>
 #define MAX_BROADCAST_SIZE 1400
 
-#ifndef errno
-extern int errno;
-#endif
-static struct timeval timeout = { 3, 0 };
-
+static struct timeval timeout = {3, 0};
 
 /*
  * pmapper remote-call-service interface.
@@ -65,42 +63,46 @@ static struct timeval timeout = { 3, 0 };
  * which will look up a service program in the port maps, and then
  * remotely call that routine with the given parameters.  This allows
  * programs to do a lookup and call in one step.
-*/
+ */
 enum clnt_stat
-pmap_rmtcall(addr, prog, vers, proc, xdrargs, argsp, xdrres, resp, tout, port_ptr)
-       struct sockaddr_in *addr;
-       u_long prog, vers, proc;
-       xdrproc_t xdrargs, xdrres;
-       caddr_t argsp, resp;
-       struct timeval tout;
-       u_long *port_ptr;
+pmap_rmtcall (addr, prog, vers, proc, xdrargs, argsp, xdrres, resp, tout, port_ptr)
+     struct sockaddr_in *addr;
+     u_long prog, vers, proc;
+     xdrproc_t xdrargs, xdrres;
+     caddr_t argsp, resp;
+     struct timeval tout;
+     u_long *port_ptr;
 {
-       int socket = -1;
-       register CLIENT *client;
-       struct rmtcallargs a;
-       struct rmtcallres r;
-       enum clnt_stat stat;
+  int socket = -1;
+  CLIENT *client;
+  struct rmtcallargs a;
+  struct rmtcallres r;
+  enum clnt_stat stat;
 
-       addr->sin_port = htons(PMAPPORT);
-       client = clntudp_create(addr, PMAPPROG, PMAPVERS, timeout, &socket);
-       if (client != (CLIENT *)NULL) {
-               a.prog = prog;
-               a.vers = vers;
-               a.proc = proc;
-               a.args_ptr = argsp;
-               a.xdr_args = xdrargs;
-               r.port_ptr = port_ptr;
-               r.results_ptr = resp;
-               r.xdr_results = xdrres;
-               stat = CLNT_CALL(client, PMAPPROC_CALLIT, xdr_rmtcall_args, &a,
-                   xdr_rmtcallres, &r, tout);
-               CLNT_DESTROY(client);
-       } else {
-               stat = RPC_FAILED;
-       }
-       /* (void)close(socket); CLNT_DESTROY already closed it */
-       addr->sin_port = 0;
-       return (stat);
+  addr->sin_port = htons (PMAPPORT);
+  client = clntudp_create (addr, PMAPPROG, PMAPVERS, timeout, &socket);
+  if (client != (CLIENT *) NULL)
+    {
+      a.prog = prog;
+      a.vers = vers;
+      a.proc = proc;
+      a.args_ptr = argsp;
+      a.xdr_args = xdrargs;
+      r.port_ptr = port_ptr;
+      r.results_ptr = resp;
+      r.xdr_results = xdrres;
+      stat = CLNT_CALL (client, PMAPPROC_CALLIT, (xdrproc_t)xdr_rmtcall_args,
+                       (caddr_t)&a, (xdrproc_t)xdr_rmtcallres,
+                       (caddr_t)&r, tout);
+      CLNT_DESTROY (client);
+    }
+  else
+    {
+      stat = RPC_FAILED;
+    }
+  /* (void)close(socket); CLNT_DESTROY already closed it */
+  addr->sin_port = 0;
+  return stat;
 }
 
 
@@ -109,30 +111,31 @@ pmap_rmtcall(addr, prog, vers, proc, xdrargs, argsp, xdrres, resp, tout, port_pt
  * written for XDR_ENCODE direction only
  */
 bool_t
-xdr_rmtcall_args(xdrs, cap)
-       register XDR *xdrs;
-       register struct rmtcallargs *cap;
+xdr_rmtcall_args (xdrs, cap)
+     XDR *xdrs;
+     struct rmtcallargs *cap;
 {
-       u_int lenposition, argposition, position;
+  u_int lenposition, argposition, position;
 
-       if (xdr_u_long(xdrs, &(cap->prog)) &&
-           xdr_u_long(xdrs, &(cap->vers)) &&
-           xdr_u_long(xdrs, &(cap->proc))) {
-               lenposition = XDR_GETPOS(xdrs);
-               if (! xdr_u_long(xdrs, &(cap->arglen)))
-                   return (FALSE);
-               argposition = XDR_GETPOS(xdrs);
-               if (! (*(cap->xdr_args))(xdrs, cap->args_ptr))
-                   return (FALSE);
-               position = XDR_GETPOS(xdrs);
-               cap->arglen = (u_long)position - (u_long)argposition;
-               XDR_SETPOS(xdrs, lenposition);
-               if (! xdr_u_long(xdrs, &(cap->arglen)))
-                   return (FALSE);
-               XDR_SETPOS(xdrs, position);
-               return (TRUE);
-       }
-       return (FALSE);
+  if (xdr_u_long (xdrs, &(cap->prog)) &&
+      xdr_u_long (xdrs, &(cap->vers)) &&
+      xdr_u_long (xdrs, &(cap->proc)))
+    {
+      lenposition = XDR_GETPOS (xdrs);
+      if (!xdr_u_long (xdrs, &(cap->arglen)))
+       return FALSE;
+      argposition = XDR_GETPOS (xdrs);
+      if (!(*(cap->xdr_args)) (xdrs, cap->args_ptr))
+       return FALSE;
+      position = XDR_GETPOS (xdrs);
+      cap->arglen = (u_long) position - (u_long) argposition;
+      XDR_SETPOS (xdrs, lenposition);
+      if (!xdr_u_long (xdrs, &(cap->arglen)))
+       return FALSE;
+      XDR_SETPOS (xdrs, position);
+      return TRUE;
+    }
+  return FALSE;
 }
 
 /*
@@ -140,19 +143,20 @@ xdr_rmtcall_args(xdrs, cap)
  * written for XDR_DECODE direction only
  */
 bool_t
-xdr_rmtcallres(xdrs, crp)
-       register XDR *xdrs;
-       register struct rmtcallres *crp;
+xdr_rmtcallres (xdrs, crp)
+     XDR *xdrs;
+     struct rmtcallres *crp;
 {
-       caddr_t port_ptr;
+  caddr_t port_ptr;
 
-       port_ptr = (caddr_t)crp->port_ptr;
-       if (xdr_reference(xdrs, &port_ptr, sizeof (u_long),
-           xdr_u_long) && xdr_u_long(xdrs, &crp->resultslen)) {
-               crp->port_ptr = (u_long *)port_ptr;
-               return ((*(crp->xdr_results))(xdrs, crp->results_ptr));
-       }
-       return (FALSE);
+  port_ptr = (caddr_t) crp->port_ptr;
+  if (xdr_reference (xdrs, &port_ptr, sizeof (u_long), (xdrproc_t) xdr_u_long)
+      && xdr_u_long (xdrs, &crp->resultslen))
+    {
+      crp->port_ptr = (u_long *) port_ptr;
+      return (*(crp->xdr_results)) (xdrs, crp->results_ptr);
+    }
+  return FALSE;
 }
 
 
@@ -163,231 +167,253 @@ xdr_rmtcallres(xdrs, crp)
  */
 
 static int
-getbroadcastnets(addrs, sock, buf)
-       struct in_addr *addrs;
-       int sock;  /* any valid socket will do */
-       char *buf;  /* why allocate more when we can use existing... */
+getbroadcastnets (struct in_addr *addrs, int sock, char *buf)
+  /* int sock:  any valid socket will do */
+  /* char *buf:        why allocate more when we can use existing... */
 {
-       struct ifconf ifc;
-        struct ifreq ifreq, *ifr;
-       struct sockaddr_in *sin;
-        int n, i;
+  struct ifconf ifc;
+  struct ifreq ifreq, *ifr;
+  struct sockaddr_in *sin;
+  int n, i;
 
-        ifc.ifc_len = UDPMSGSIZE;
-        ifc.ifc_buf = buf;
-        if (ioctl(sock, SIOCGIFCONF, (char *)&ifc) < 0) {
-                perror(_("broadcast: ioctl (get interface configuration)"));
-                return (0);
-        }
-        ifr = ifc.ifc_req;
-        for (i = 0, n = ifc.ifc_len/sizeof (struct ifreq); n > 0; n--, ifr++) {
-                ifreq = *ifr;
-                if (ioctl(sock, SIOCGIFFLAGS, (char *)&ifreq) < 0) {
-                        perror(_("broadcast: ioctl (get interface flags)"));
-                        continue;
-                }
-                if ((ifreq.ifr_flags & IFF_BROADCAST) &&
-                   (ifreq.ifr_flags & IFF_UP) &&
-                   ifr->ifr_addr.sa_family == AF_INET) {
-                       sin = (struct sockaddr_in *)&ifr->ifr_addr;
-#ifdef SIOCGIFBRDADDR   /* 4.3BSD */
-                       if (ioctl(sock, SIOCGIFBRDADDR, (char *)&ifreq) < 0) {
-                               addrs[i++] = inet_makeaddr(inet_netof
-                           /* Changed to pass struct instead of s_addr member
-                              by roland@gnu.  */
-                           (sin->sin_addr), INADDR_ANY);
-                       } else {
-                               addrs[i++] = ((struct sockaddr_in*)
-                                 &ifreq.ifr_addr)->sin_addr;
-                       }
+  ifc.ifc_len = UDPMSGSIZE;
+  ifc.ifc_buf = buf;
+  if (ioctl (sock, SIOCGIFCONF, (char *) &ifc) < 0)
+    {
+      perror (_("broadcast: ioctl (get interface configuration)"));
+      return (0);
+    }
+  ifr = ifc.ifc_req;
+  for (i = 0, n = ifc.ifc_len / sizeof (struct ifreq); n > 0; n--, ifr++)
+    {
+      ifreq = *ifr;
+      if (ioctl (sock, SIOCGIFFLAGS, (char *) &ifreq) < 0)
+       {
+         perror (_("broadcast: ioctl (get interface flags)"));
+         continue;
+       }
+      if ((ifreq.ifr_flags & IFF_BROADCAST) &&
+         (ifreq.ifr_flags & IFF_UP) &&
+         ifr->ifr_addr.sa_family == AF_INET)
+       {
+         sin = (struct sockaddr_in *) &ifr->ifr_addr;
+#ifdef SIOCGIFBRDADDR          /* 4.3BSD */
+         if (ioctl (sock, SIOCGIFBRDADDR, (char *) &ifreq) < 0)
+           {
+             addrs[i++] = inet_makeaddr (inet_netof
+             /* Changed to pass struct instead of s_addr member
+                by roland@gnu.  */
+                                         (sin->sin_addr), INADDR_ANY);
+           }
+         else
+           {
+             addrs[i++] = ((struct sockaddr_in *)
+                           &ifreq.ifr_addr)->sin_addr;
+           }
 #else /* 4.2 BSD */
-                       addrs[i++] = inet_makeaddr(inet_netof
-                         (sin->sin_addr.s_addr), INADDR_ANY);
+         addrs[i++] = inet_makeaddr (inet_netof
+                                     (sin->sin_addr.s_addr), INADDR_ANY);
 #endif
-               }
        }
-       return (i);
+    }
+  return i;
 }
 
 
 enum clnt_stat
-clnt_broadcast(prog, vers, proc, xargs, argsp, xresults, resultsp, eachresult)
-       u_long          prog;           /* program number */
-       u_long          vers;           /* version number */
-       u_long          proc;           /* procedure number */
-       xdrproc_t       xargs;          /* xdr routine for args */
-       caddr_t         argsp;          /* pointer to args */
-       xdrproc_t       xresults;       /* xdr routine for results */
-       caddr_t         resultsp;       /* pointer to results */
-       resultproc_t    eachresult;     /* call with each result obtained */
+clnt_broadcast (prog, vers, proc, xargs, argsp, xresults, resultsp, eachresult)
+     u_long prog;              /* program number */
+     u_long vers;              /* version number */
+     u_long proc;              /* procedure number */
+     xdrproc_t xargs;          /* xdr routine for args */
+     caddr_t argsp;            /* pointer to args */
+     xdrproc_t xresults;       /* xdr routine for results */
+     caddr_t resultsp;         /* pointer to results */
+     resultproc_t eachresult;  /* call with each result obtained */
 {
-       enum clnt_stat stat;
-       AUTH *unix_auth = authunix_create_default();
-       XDR xdr_stream;
-       register XDR *xdrs = &xdr_stream;
-       int outlen, inlen, fromlen, nets;
-       register int sock;
-       int on = 1;
+  enum clnt_stat stat;
+  AUTH *unix_auth = authunix_create_default ();
+  XDR xdr_stream;
+  XDR *xdrs = &xdr_stream;
+  int outlen, inlen, fromlen, nets;
+  int sock;
+  int on = 1;
 #ifdef FD_SETSIZE
-       fd_set mask;
-       fd_set readfds;
+  fd_set mask;
+  fd_set readfds;
 #else
-       int readfds;
-       register int mask;
+  int readfds;
+  int mask;
 #endif /* def FD_SETSIZE */
-       register int i;
-       bool_t done = FALSE;
-       register u_long xid;
-       u_long port;
-       struct in_addr addrs[20];
-       struct sockaddr_in baddr, raddr; /* broadcast and response addresses */
-       struct rmtcallargs a;
-       struct rmtcallres r;
-       struct rpc_msg msg;
-       struct timeval t, t1;
-       char outbuf[MAX_BROADCAST_SIZE], inbuf[UDPMSGSIZE];
+  int i;
+  bool_t done = FALSE;
+  u_long xid;
+  u_long port;
+  struct in_addr addrs[20];
+  struct sockaddr_in baddr, raddr;     /* broadcast and response addresses */
+  struct rmtcallargs a;
+  struct rmtcallres r;
+  struct rpc_msg msg;
+  struct timeval t, t1;
+  char outbuf[MAX_BROADCAST_SIZE], inbuf[UDPMSGSIZE];
 
-       /*
-        * initialization: create a socket, a broadcast address, and
-        * preserialize the arguments into a send buffer.
-        */
-       if ((sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0) {
-               perror(_("Cannot create socket for broadcast rpc"));
-               stat = RPC_CANTSEND;
-               goto done_broad;
-       }
+  /*
+   * initialization: create a socket, a broadcast address, and
+   * preserialize the arguments into a send buffer.
+   */
+  if ((sock = socket (AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0)
+    {
+      perror (_("Cannot create socket for broadcast rpc"));
+      stat = RPC_CANTSEND;
+      goto done_broad;
+    }
 #ifdef SO_BROADCAST
-       if (setsockopt(sock, SOL_SOCKET, SO_BROADCAST, &on, sizeof (on)) < 0) {
-               perror(_("Cannot set socket option SO_BROADCAST"));
-               stat = RPC_CANTSEND;
-               goto done_broad;
-       }
+  if (setsockopt (sock, SOL_SOCKET, SO_BROADCAST, &on, sizeof (on)) < 0)
+    {
+      perror (_("Cannot set socket option SO_BROADCAST"));
+      stat = RPC_CANTSEND;
+      goto done_broad;
+    }
 #endif /* def SO_BROADCAST */
 #ifdef FD_SETSIZE
-       FD_ZERO(&mask);
-       FD_SET(sock, &mask);
+  FD_ZERO (&mask);
+  FD_SET (sock, &mask);
 #else
-       mask = (1 << sock);
+  mask = (1 << sock);
 #endif /* def FD_SETSIZE */
-       nets = getbroadcastnets(addrs, sock, inbuf);
-       bzero((char *)&baddr, sizeof (baddr));
-       baddr.sin_family = AF_INET;
-       baddr.sin_port = htons(PMAPPORT);
-       baddr.sin_addr.s_addr = htonl(INADDR_ANY);
-/*     baddr.sin_addr.S_un.S_addr = htonl(INADDR_ANY); */
-       (void)gettimeofday(&t, (struct timezone *)0);
-       msg.rm_xid = xid = getpid() ^ t.tv_sec ^ t.tv_usec;
-       t.tv_usec = 0;
-       msg.rm_direction = CALL;
-       msg.rm_call.cb_rpcvers = RPC_MSG_VERSION;
-       msg.rm_call.cb_prog = PMAPPROG;
-       msg.rm_call.cb_vers = PMAPVERS;
-       msg.rm_call.cb_proc = PMAPPROC_CALLIT;
-       msg.rm_call.cb_cred = unix_auth->ah_cred;
-       msg.rm_call.cb_verf = unix_auth->ah_verf;
-       a.prog = prog;
-       a.vers = vers;
-       a.proc = proc;
-       a.xdr_args = xargs;
-       a.args_ptr = argsp;
-       r.port_ptr = &port;
-       r.xdr_results = xresults;
-       r.results_ptr = resultsp;
-       xdrmem_create(xdrs, outbuf, MAX_BROADCAST_SIZE, XDR_ENCODE);
-       if ((! xdr_callmsg(xdrs, &msg)) || (! xdr_rmtcall_args(xdrs, &a))) {
-               stat = RPC_CANTENCODEARGS;
-               goto done_broad;
+  nets = getbroadcastnets (addrs, sock, inbuf);
+  bzero ((char *) &baddr, sizeof (baddr));
+  baddr.sin_family = AF_INET;
+  baddr.sin_port = htons (PMAPPORT);
+  baddr.sin_addr.s_addr = htonl (INADDR_ANY);
+/*      baddr.sin_addr.S_un.S_addr = htonl(INADDR_ANY); */
+  (void) gettimeofday (&t, (struct timezone *) 0);
+  msg.rm_xid = xid = getpid () ^ t.tv_sec ^ t.tv_usec;
+  t.tv_usec = 0;
+  msg.rm_direction = CALL;
+  msg.rm_call.cb_rpcvers = RPC_MSG_VERSION;
+  msg.rm_call.cb_prog = PMAPPROG;
+  msg.rm_call.cb_vers = PMAPVERS;
+  msg.rm_call.cb_proc = PMAPPROC_CALLIT;
+  msg.rm_call.cb_cred = unix_auth->ah_cred;
+  msg.rm_call.cb_verf = unix_auth->ah_verf;
+  a.prog = prog;
+  a.vers = vers;
+  a.proc = proc;
+  a.xdr_args = xargs;
+  a.args_ptr = argsp;
+  r.port_ptr = &port;
+  r.xdr_results = xresults;
+  r.results_ptr = resultsp;
+  xdrmem_create (xdrs, outbuf, MAX_BROADCAST_SIZE, XDR_ENCODE);
+  if ((!xdr_callmsg (xdrs, &msg)) || (!xdr_rmtcall_args (xdrs, &a)))
+    {
+      stat = RPC_CANTENCODEARGS;
+      goto done_broad;
+    }
+  outlen = (int) xdr_getpos (xdrs);
+  xdr_destroy (xdrs);
+  /*
+   * Basic loop: broadcast a packet and wait a while for response(s).
+   * The response timeout grows larger per iteration.
+   */
+  for (t.tv_sec = 4; t.tv_sec <= 14; t.tv_sec += 2)
+    {
+      for (i = 0; i < nets; i++)
+       {
+         baddr.sin_addr = addrs[i];
+         if (sendto (sock, outbuf, outlen, 0,
+                     (struct sockaddr *) &baddr,
+                     sizeof (struct sockaddr)) != outlen)
+           {
+             perror (_("Cannot send broadcast packet"));
+             stat = RPC_CANTSEND;
+             goto done_broad;
+           }
        }
-       outlen = (int)xdr_getpos(xdrs);
-       xdr_destroy(xdrs);
-       /*
-        * Basic loop: broadcast a packet and wait a while for response(s).
-        * The response timeout grows larger per iteration.
-        */
-       for (t.tv_sec = 4; t.tv_sec <= 14; t.tv_sec += 2) {
-               for (i = 0; i < nets; i++) {
-                       baddr.sin_addr = addrs[i];
-                       if (sendto(sock, outbuf, outlen, 0,
-                               (struct sockaddr *)&baddr,
-                               sizeof (struct sockaddr)) != outlen) {
-                               perror(_("Cannot send broadcast packet"));
-                               stat = RPC_CANTSEND;
-                               goto done_broad;
-                       }
-               }
-               if (eachresult == NULL) {
-                       stat = RPC_SUCCESS;
-                       goto done_broad;
-               }
-       recv_again:
-               msg.acpted_rply.ar_verf = _null_auth;
-               msg.acpted_rply.ar_results.where = (caddr_t)&r;
-                msg.acpted_rply.ar_results.proc = xdr_rmtcallres;
-               readfds = mask;
-               t1 = t;
-               switch (select(_rpc_dtablesize(), &readfds, (int *)NULL,
-                              (int *)NULL, &t1)) {
+      if (eachresult == NULL)
+       {
+         stat = RPC_SUCCESS;
+         goto done_broad;
+       }
+    recv_again:
+      msg.acpted_rply.ar_verf = _null_auth;
+      msg.acpted_rply.ar_results.where = (caddr_t) & r;
+      msg.acpted_rply.ar_results.proc = (xdrproc_t) xdr_rmtcallres;
+      readfds = mask;
+      t1 = t;
+      switch (select (_rpc_dtablesize (), &readfds, (fd_set *) NULL,
+                     (fd_set *) NULL, &t1))
+       {
 
-               case 0:  /* timed out */
-                       stat = RPC_TIMEDOUT;
-                       continue;
+       case 0:         /* timed out */
+         stat = RPC_TIMEDOUT;
+         continue;
 
-               case -1:  /* some kind of error */
-                       if (errno == EINTR)
-                               goto recv_again;
-                       perror(_("Broadcast select problem"));
-                       stat = RPC_CANTRECV;
-                       goto done_broad;
+       case -1:                /* some kind of error */
+         if (errno == EINTR)
+           goto recv_again;
+         perror (_("Broadcast select problem"));
+         stat = RPC_CANTRECV;
+         goto done_broad;
 
-               }  /* end of select results switch */
-       try_again:
-               fromlen = sizeof(struct sockaddr);
-               inlen = recvfrom(sock, inbuf, UDPMSGSIZE, 0,
-                       (struct sockaddr *)&raddr, &fromlen);
-               if (inlen < 0) {
-                       if (errno == EINTR)
-                               goto try_again;
-                       perror(_("Cannot receive reply to broadcast"));
-                       stat = RPC_CANTRECV;
-                       goto done_broad;
-               }
-               if (inlen < sizeof(u_long))
-                       goto recv_again;
-               /*
-                * see if reply transaction id matches sent id.
-                * If so, decode the results.
-                */
-               xdrmem_create(xdrs, inbuf, (u_int)inlen, XDR_DECODE);
-               if (xdr_replymsg(xdrs, &msg)) {
-                       if ((msg.rm_xid == xid) &&
-                               (msg.rm_reply.rp_stat == MSG_ACCEPTED) &&
-                               (msg.acpted_rply.ar_stat == SUCCESS)) {
-                               raddr.sin_port = htons((u_short)port);
-                               done = (*eachresult)(resultsp, &raddr);
-                       }
-                       /* otherwise, we just ignore the errors ... */
-               } else {
+       }                       /* end of select results switch */
+    try_again:
+      fromlen = sizeof (struct sockaddr);
+      inlen = recvfrom (sock, inbuf, UDPMSGSIZE, 0,
+                       (struct sockaddr *) &raddr, &fromlen);
+      if (inlen < 0)
+       {
+         if (errno == EINTR)
+           goto try_again;
+         perror (_("Cannot receive reply to broadcast"));
+         stat = RPC_CANTRECV;
+         goto done_broad;
+       }
+      if (inlen < sizeof (u_long))
+       goto recv_again;
+      /*
+       * see if reply transaction id matches sent id.
+       * If so, decode the results.
+       */
+      xdrmem_create (xdrs, inbuf, (u_int) inlen, XDR_DECODE);
+      if (xdr_replymsg (xdrs, &msg))
+       {
+         if ((msg.rm_xid == xid) &&
+             (msg.rm_reply.rp_stat == MSG_ACCEPTED) &&
+             (msg.acpted_rply.ar_stat == SUCCESS))
+           {
+             raddr.sin_port = htons ((u_short) port);
+             done = (*eachresult) (resultsp, &raddr);
+           }
+         /* otherwise, we just ignore the errors ... */
+       }
+      else
+       {
 #ifdef notdef
-                       /* some kind of deserialization problem ... */
-                       if (msg.rm_xid == xid)
-                               fprintf(stderr, "Broadcast deserialization problem");
-                       /* otherwise, just random garbage */
+         /* some kind of deserialization problem ... */
+         if (msg.rm_xid == xid)
+           fprintf (stderr, "Broadcast deserialization problem");
+         /* otherwise, just random garbage */
 #endif
-               }
-               xdrs->x_op = XDR_FREE;
-               msg.acpted_rply.ar_results.proc = xdr_void;
-               (void)xdr_replymsg(xdrs, &msg);
-               (void)(*xresults)(xdrs, resultsp);
-               xdr_destroy(xdrs);
-               if (done) {
-                       stat = RPC_SUCCESS;
-                       goto done_broad;
-               } else {
-                       goto recv_again;
-               }
        }
+      xdrs->x_op = XDR_FREE;
+      msg.acpted_rply.ar_results.proc = (xdrproc_t)xdr_void;
+      (void) xdr_replymsg (xdrs, &msg);
+      (void) (*xresults) (xdrs, resultsp);
+      xdr_destroy (xdrs);
+      if (done)
+       {
+         stat = RPC_SUCCESS;
+         goto done_broad;
+       }
+      else
+       {
+         goto recv_again;
+       }
+    }
 done_broad:
-       (void)close(sock);
-       AUTH_DESTROY(unix_auth);
-       return (stat);
+  (void) close (sock);
+  AUTH_DESTROY (unix_auth);
+  return stat;
 }
index fbb8761..fb08604 100644 (file)
@@ -31,7 +31,7 @@
 /*
  * From: @(#)rpc_clntout.c 1.11 89/02/22 (C) 1987 SMI
  */
-char clntout_rcsid[] = 
+char clntout_rcsid[] =
   "$Id$";
 
 /*
@@ -46,121 +46,141 @@ char clntout_rcsid[] =
 #include "proto.h"
 
 #define DEFAULT_TIMEOUT 25     /* in seconds */
-static char RESULT[] = "clnt_res";
+static const char RESULT[] = "clnt_res";
 
-static void write_program(definition *def);
-static void printbody(proc_list *proc);
-static const char *ampr(const char *type);
-static void printbody(proc_list *proc);
+static void write_program (definition * def);
+static void printbody (proc_list * proc);
+static const char *ampr (const char *type);
+static void printbody (proc_list * proc);
 
 
 void
-write_stubs(void)
+write_stubs (void)
 {
-       list *l;
-       definition *def;
-
-       f_print(fout,
-               "\n/* Default timeout can be changed using clnt_control() */\n");
-       f_print(fout, "static struct timeval TIMEOUT = { %d, 0 };\n",
-               DEFAULT_TIMEOUT);
-       for (l = defined; l != NULL; l = l->next) {
-               def = (definition *) l->val;
-               if (def->def_kind == DEF_PROGRAM) {
-                       write_program(def);
-               }
+  list *l;
+  definition *def;
+
+  f_print (fout,
+          "\n/* Default timeout can be changed using clnt_control() */\n");
+  f_print (fout, "static struct timeval TIMEOUT = { %d, 0 };\n",
+          DEFAULT_TIMEOUT);
+  for (l = defined; l != NULL; l = l->next)
+    {
+      def = (definition *) l->val;
+      if (def->def_kind == DEF_PROGRAM)
+       {
+         write_program (def);
        }
+    }
 }
 
 static void
-write_program(definition *def)
+write_program (definition * def)
 {
-       version_list *vp;
-       proc_list *proc;
-
-       for (vp = def->def.pr.versions; vp != NULL; vp = vp->next) {
-               for (proc = vp->procs; proc != NULL; proc = proc->next) {
-                       f_print(fout, "\n");
-                       ptype(proc->res_prefix, proc->res_type, 1);
-                       f_print(fout, "*\n");
-                       pvname(proc->proc_name, vp->vers_num);
-                       printarglist( proc, "clnt", "CLIENT *" );
-                       f_print(fout, "{\n");
-                       printbody(proc);
-                       f_print(fout, "}\n");
-               }
+  version_list *vp;
+  proc_list *proc;
+
+  for (vp = def->def.pr.versions; vp != NULL; vp = vp->next)
+    {
+      for (proc = vp->procs; proc != NULL; proc = proc->next)
+       {
+         f_print (fout, "\n");
+         ptype (proc->res_prefix, proc->res_type, 1);
+         f_print (fout, "*\n");
+         pvname (proc->proc_name, vp->vers_num);
+         printarglist (proc, "clnt", "CLIENT *");
+         f_print (fout, "{\n");
+         printbody (proc);
+         f_print (fout, "}\n");
        }
+    }
 }
 
 /* Writes out declarations of procedure's argument list.
    In either ANSI C style, in one of old rpcgen style (pass by reference),
    or new rpcgen style (multiple arguments, pass by value);
  */
+ */
 
 /* sample addargname = "clnt"; sample addargtype = "CLIENT * " */
 
-void printarglist(proc_list *proc,
-                 const char *addargname, const char *addargtype)
+void
+printarglist (proc_list * proc,
+             const char *addargname, const char *addargtype)
 {
 
   decl_list *l;
 
-  if (!newstyle) {    /* old style: always pass argument by reference */
-    if (Cflag) {      /* C++ style heading */
-      f_print(fout, "(");
-      ptype(proc->args.decls->decl.prefix, proc->args.decls->decl.type, 1);
-      f_print(fout, "*argp, %s%s)\n", addargtype, addargname );
+  if (!newstyle)
+    {                          /* old style: always pass argument by reference */
+      if (Cflag)
+       {                       /* C++ style heading */
+         f_print (fout, "(");
+         ptype (proc->args.decls->decl.prefix, proc->args.decls->decl.type, 1);
+         f_print (fout, "*argp, %s%s)\n", addargtype, addargname);
+       }
+      else
+       {
+         f_print (fout, "(argp, %s)\n", addargname);
+         f_print (fout, "\t");
+         ptype (proc->args.decls->decl.prefix, proc->args.decls->decl.type, 1);
+         f_print (fout, "*argp;\n");
+       }
     }
-    else {
-      f_print(fout, "(argp, %s)\n", addargname);
-      f_print(fout, "\t");
-      ptype(proc->args.decls->decl.prefix, proc->args.decls->decl.type, 1);
-      f_print(fout, "*argp;\n");
+  else if (streq (proc->args.decls->decl.type, "void"))
+    {
+      /* newstyle, 0 argument */
+      if (Cflag)
+       f_print (fout, "(%s%s)\n", addargtype, addargname);
+      else
+       f_print (fout, "(%s)\n", addargname);
     }
-  } else if (streq( proc->args.decls->decl.type, "void")) {
-    /* newstyle, 0 argument */
-    if( Cflag )
-      f_print(fout, "(%s%s)\n", addargtype, addargname );
-    else
-      f_print(fout, "(%s)\n", addargname);
-  } else {
-    /* new style, 1 or multiple arguments */
-    if( !Cflag ) {
-      f_print(fout, "(");
-      for (l = proc->args.decls;  l != NULL; l = l->next)
-       f_print(fout, "%s, ", l->decl.name);
-      f_print(fout, "%s)\n", addargname );
-      for (l = proc->args.decls; l != NULL; l = l->next) {
-       pdeclaration(proc->args.argname, &l->decl, 1, ";\n" );
-      }
-    } else {  /* C++ style header */
-      f_print(fout, "(");
-      for(l = proc->args.decls; l != NULL; l = l->next) {
-       pdeclaration(proc->args.argname, &l->decl, 0, ", " );
-      }
-      f_print(fout, " %s%s)\n", addargtype, addargname );
+  else
+    {
+      /* new style, 1 or multiple arguments */
+      if (!Cflag)
+       {
+         f_print (fout, "(");
+         for (l = proc->args.decls; l != NULL; l = l->next)
+           f_print (fout, "%s, ", l->decl.name);
+         f_print (fout, "%s)\n", addargname);
+         for (l = proc->args.decls; l != NULL; l = l->next)
+           {
+             pdeclaration (proc->args.argname, &l->decl, 1, ";\n");
+           }
+       }
+      else
+       {                       /* C++ style header */
+         f_print (fout, "(");
+         for (l = proc->args.decls; l != NULL; l = l->next)
+           {
+             pdeclaration (proc->args.argname, &l->decl, 0, ", ");
+           }
+         f_print (fout, " %s%s)\n", addargtype, addargname);
+       }
     }
-  }
 
-  if( !Cflag )
-    f_print(fout, "\t%s%s;\n", addargtype, addargname );
+  if (!Cflag)
+    f_print (fout, "\t%s%s;\n", addargtype, addargname);
 }
 
 
 
 static
 const char *
-ampr(const char *type)
+ampr (const char *type)
 {
-       if (isvectordef(type, REL_ALIAS)) {
-               return ("");
-       } else {
-               return ("&");
-       }
+  if (isvectordef (type, REL_ALIAS))
+    {
+      return "";
+    }
+  else
+    {
+      return "&";
+    }
 }
 
 static void
-printbody(proc_list *proc)
+printbody (proc_list * proc)
 {
   decl_list *l;
   bool_t args2 = (proc->arg_num > 1);
@@ -168,55 +188,68 @@ printbody(proc_list *proc)
 
   /* For new style with multiple arguments, need a structure in which
      to stuff the arguments. */
-       if ( newstyle && args2) {
-               f_print(fout, "\t%s", proc->args.argname);
-               f_print(fout, " arg;\n");
-       }
-       f_print(fout, "\tstatic ");
-       if (streq(proc->res_type, "void")) {
-               f_print(fout, "char ");
-       } else {
-               ptype(proc->res_prefix, proc->res_type, 0);
-       }
-       f_print(fout, "%s;\n",RESULT);
-       f_print(fout, "\n");
-        f_print(fout, "\tmemset((char *)%s%s, 0, sizeof(%s));\n",
-               ampr(proc->res_type ), RESULT, RESULT);
-       if (newstyle && !args2 && (streq( proc->args.decls->decl.type, "void"))) {
-         /* newstyle, 0 arguments */
-         f_print(fout,
-                   "\tif (clnt_call(clnt, %s, xdr_void", proc->proc_name);
-         f_print(fout,
-                 ", NULL, xdr_%s, %s,%s, TIMEOUT) != RPC_SUCCESS) {\n",
-                 stringfix(proc->res_type), ampr(proc->res_type), RESULT);
-
-       } else if ( newstyle && args2) {
-         /* newstyle, multiple arguments:  stuff arguments into structure */
-         for (l = proc->args.decls;  l != NULL; l = l->next) {
-           f_print(fout, "\targ.%s = %s;\n",
-                   l->decl.name, l->decl.name);
-         }
-         f_print(fout,
-                 "\tif (clnt_call(clnt, %s, xdr_%s", proc->proc_name,
-                 proc->args.argname);
-         f_print(fout,
-                     ", &arg, xdr_%s, %s%s, TIMEOUT) != RPC_SUCCESS) {\n",
-                 stringfix(proc->res_type), ampr(proc->res_type), RESULT);
-       } else {  /* single argument, new or old style */
-             f_print(fout,
-                     "\tif (clnt_call(clnt, %s, xdr_%s, %s%s, xdr_%s, %s%s, TIMEOUT) != RPC_SUCCESS) {\n",
-                     proc->proc_name,
-                     stringfix(proc->args.decls->decl.type),
-                     (newstyle ? "&" : ""),
-                     (newstyle ? proc->args.decls->decl.name : "argp"),
-                     stringfix(proc->res_type), ampr(proc->res_type),RESULT);
-           }
-       f_print(fout, "\t\treturn (NULL);\n");
-       f_print(fout, "\t}\n");
-       if (streq(proc->res_type, "void")) {
-               f_print(fout, "\treturn ((void *)%s%s);\n",
-                       ampr(proc->res_type),RESULT);
-       } else {
-               f_print(fout, "\treturn (%s%s);\n", ampr(proc->res_type),RESULT);
+  if (newstyle && args2)
+    {
+      f_print (fout, "\t%s", proc->args.argname);
+      f_print (fout, " arg;\n");
+    }
+  f_print (fout, "\tstatic ");
+  if (streq (proc->res_type, "void"))
+    {
+      f_print (fout, "char ");
+    }
+  else
+    {
+      ptype (proc->res_prefix, proc->res_type, 0);
+    }
+  f_print (fout, "%s;\n", RESULT);
+  f_print (fout, "\n");
+  f_print (fout, "\tmemset((char *)%s%s, 0, sizeof(%s));\n",
+          ampr (proc->res_type), RESULT, RESULT);
+  if (newstyle && !args2 && (streq (proc->args.decls->decl.type, "void")))
+    {
+      /* newstyle, 0 arguments */
+      f_print (fout,
+              "\tif (clnt_call(clnt, %s, xdr_void", proc->proc_name);
+      f_print (fout,
+              ", NULL, xdr_%s, %s,%s, TIMEOUT) != RPC_SUCCESS) {\n",
+              stringfix (proc->res_type), ampr (proc->res_type), RESULT);
+
+    }
+  else if (newstyle && args2)
+    {
+      /* newstyle, multiple arguments:  stuff arguments into structure */
+      for (l = proc->args.decls; l != NULL; l = l->next)
+       {
+         f_print (fout, "\targ.%s = %s;\n",
+                  l->decl.name, l->decl.name);
        }
+      f_print (fout,
+              "\tif (clnt_call(clnt, %s, xdr_%s", proc->proc_name,
+              proc->args.argname);
+      f_print (fout,
+              ", &arg, xdr_%s, %s%s, TIMEOUT) != RPC_SUCCESS) {\n",
+              stringfix (proc->res_type), ampr (proc->res_type), RESULT);
+    }
+  else
+    {                          /* single argument, new or old style */
+      f_print (fout,
+              "\tif (clnt_call(clnt, %s, xdr_%s, %s%s, xdr_%s, %s%s, TIMEOUT) != RPC_SUCCESS) {\n",
+              proc->proc_name,
+              stringfix (proc->args.decls->decl.type),
+              (newstyle ? "&" : ""),
+              (newstyle ? proc->args.decls->decl.name : "argp"),
+              stringfix (proc->res_type), ampr (proc->res_type), RESULT);
+    }
+  f_print (fout, "\t\treturn (NULL);\n");
+  f_print (fout, "\t}\n");
+  if (streq (proc->res_type, "void"))
+    {
+      f_print (fout, "\treturn ((void *)%s%s);\n",
+              ampr (proc->res_type), RESULT);
+    }
+  else
+    {
+      f_print (fout, "\treturn (%s%s);\n", ampr (proc->res_type), RESULT);
+    }
 }