Bring in a transport-independent RPC (TI-RPC).
[dragonfly.git] / lib / libc / rpc / pmap_rmt.c
index e8ae0b2..5b59abf 100644 (file)
@@ -28,7 +28,8 @@
  *
  * @(#)pmap_rmt.c 1.21 87/08/27 Copyr 1984 Sun Micro
  * @(#)pmap_rmt.c      2.2 88/08/01 4.0 RPCSRC
- * $FreeBSD: src/lib/libc/rpc/pmap_rmt.c,v 1.16.2.1 2002/06/30 23:34:58 iedowse Exp $
+ * $NetBSD: pmap_rmt.c,v 1.29 2000/07/06 03:10:34 christos Exp $
+ * $FreeBSD: src/lib/libc/rpc/pmap_rmt.c,v 1.20 2004/10/16 06:11:35 obrien Exp $
  * $DragonFly: src/lib/libc/rpc/pmap_rmt.c,v 1.5 2005/11/13 12:27:04 swildner Exp $
  */
 
  */
 
 #include "namespace.h"
+#include <sys/types.h>
+#include <sys/ioctl.h>
+#include <sys/poll.h>
+#include <sys/socket.h>
+
+#include <net/if.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+
+#include <assert.h>
+#include <err.h>
+#include <errno.h>
+#include <stdio.h>
+#include <string.h>
+#include <unistd.h>
+
 #include <rpc/rpc.h>
 #include <rpc/pmap_prot.h>
 #include <rpc/pmap_clnt.h>
 #include <rpc/pmap_rmt.h>
-#include <sys/socket.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <unistd.h>
-#include <errno.h>
-#include <string.h>
-#include <net/if.h>
-#include <sys/ioctl.h>
-#include <arpa/inet.h>
 #include "un-namespace.h"
 
-#define MAX_BROADCAST_SIZE 1400
-
-static struct timeval timeout = { 3, 0 };
+static const struct timeval timeout = { 3, 0 };
 
 /*
  * pmapper remote-call-service interface.
@@ -72,15 +78,18 @@ pmap_rmtcall(struct sockaddr_in *addr, u_long prog, u_long vers, u_long proc,
             xdrproc_t xdrargs, caddr_t argsp, xdrproc_t xdrres, caddr_t resp,
             struct timeval tout, u_long *port_ptr)
 {
-       int socket = -1;
+       int sock = -1;
        CLIENT *client;
        struct rmtcallargs a;
        struct rmtcallres r;
        enum clnt_stat stat;
 
+       assert(addr != NULL);
+       assert(port_ptr != NULL);
+
        addr->sin_port = htons(PMAPPORT);
-       client = clntudp_create(addr, PMAPPROG, PMAPVERS, timeout, &socket);
-       if (client != (CLIENT *)NULL) {
+       client = clntudp_create(addr, PMAPPROG, PMAPVERS, timeout, &sock);
+       if (client != NULL) {
                a.prog = prog;
                a.vers = vers;
                a.proc = proc;
@@ -89,14 +98,13 @@ pmap_rmtcall(struct sockaddr_in *addr, u_long prog, u_long vers, u_long proc,
                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);
+               stat = CLNT_CALL(client, (rpcproc_t)PMAPPROC_CALLIT,
+                   (xdrproc_t)xdr_rmtcall_args, &a, (xdrproc_t)xdr_rmtcallres,
+                   &r, tout);
                CLNT_DESTROY(client);
        } else {
                stat = RPC_FAILED;
        }
-       if (socket != -1)
-               _close(socket);
        addr->sin_port = 0;
        return (stat);
 }
@@ -111,6 +119,9 @@ xdr_rmtcall_args(XDR *xdrs, struct rmtcallargs *cap)
 {
        u_int lenposition, argposition, position;
 
+       assert(xdrs != NULL);
+       assert(cap != NULL);
+
        if (xdr_u_long(xdrs, &(cap->prog)) &&
            xdr_u_long(xdrs, &(cap->vers)) &&
            xdr_u_long(xdrs, &(cap->proc))) {
@@ -140,272 +151,14 @@ xdr_rmtcallres(XDR *xdrs, struct rmtcallres *crp)
 {
        caddr_t port_ptr;
 
-       port_ptr = (caddr_t)crp->port_ptr;
+       assert(xdrs != NULL);
+       assert(crp != NULL);
+
+       port_ptr = (caddr_t)(void *)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;
+           (xdrproc_t)xdr_u_long) && xdr_u_long(xdrs, &crp->resultslen)) {
+               crp->port_ptr = (u_long *)(void *)port_ptr;
                return ((*(crp->xdr_results))(xdrs, crp->results_ptr));
        }
        return (FALSE);
 }
-
-
-/*
- * The following is kludged-up support for simple rpc broadcasts.
- * Someday a large, complicated system will replace these trivial
- * routines which only support udp/ip .
- */
-
-static int
-getbroadcastnets(struct in_addr *addrs,
-                int sock,              /* any valid socket will do */
-                char *buf)             /* why allocxate more when we can use existing... */
-{
-       struct ifconf ifc;
-       struct ifreq ifreq, *ifr;
-       struct sockaddr_in *sin;
-       struct  in_addr addr;
-       char *cp, *cplim;
-       int n, i = 0;
-
-        ifc.ifc_len = UDPMSGSIZE;
-        ifc.ifc_buf = buf;
-        if (_ioctl(sock, SIOCGIFCONF, (char *)&ifc) < 0) {
-                perror("broadcast: ioctl (get interface configuration)");
-                return (0);
-        }
-#define max(a, b) (a > b ? a : b)
-#define size(p)        max((p).sa_len, sizeof(p))
-       cplim = buf + ifc.ifc_len; /*skip over if's with big ifr_addr's */
-       for (cp = buf; cp < cplim;
-                       cp += sizeof (ifr->ifr_name) + size(ifr->ifr_addr)) {
-               ifr = (struct ifreq *)cp;
-               if (ifr->ifr_addr.sa_family != AF_INET)
-                       continue;
-               memcpy(&ifreq, ifr, sizeof(ifreq));
-                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)) {
-                       sin = (struct sockaddr_in *)&ifr->ifr_addr;
-#ifdef SIOCGIFBRDADDR   /* 4.3BSD */
-                       if (_ioctl(sock, SIOCGIFBRDADDR, (char *)&ifreq) < 0) {
-                               addr =
-                                   inet_makeaddr(inet_netof(sin->sin_addr),
-                                   INADDR_ANY);
-                       } else {
-                               addr = ((struct sockaddr_in*)
-                                 &ifreq.ifr_addr)->sin_addr;
-                       }
-#else /* 4.2 BSD */
-                       addr = inet_makeaddr(inet_netof(sin->sin_addr),
-                           INADDR_ANY);
-#endif
-                       for (n=i-1; n>=0; n--) {
-                               if (addr.s_addr == addrs[n].s_addr)
-                                       break;
-                       }
-                       if (n<0) {
-                               addrs[i++] = addr;
-                       }
-               }
-       }
-       return (i);
-}
-
-typedef bool_t (*resultproc_t)();
-
-enum clnt_stat
-clnt_broadcast(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;
-       XDR *xdrs = &xdr_stream;
-       int outlen, inlen, fromlen, nets;
-       int sock;
-       int on = 1;
-       fd_set *fds, readfds;
-       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, tv;
-       char outbuf[MAX_BROADCAST_SIZE], inbuf[UDPMSGSIZE];
-       static u_int32_t disrupt;
-
-       if (disrupt == 0)
-               disrupt = (u_int32_t)(long)resultsp;
-
-       /*
-        * 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;
-       }
-#endif /* def SO_BROADCAST */
-       if (sock + 1 > FD_SETSIZE) {
-               int bytes = howmany(sock + 1, NFDBITS) * sizeof(fd_mask);
-               fds = (fd_set *)malloc(bytes);
-               if (fds == NULL) {
-                       stat = RPC_CANTSEND;
-                       goto done_broad;
-               }
-               memset(fds, 0, bytes);
-       } else {
-               fds = &readfds;
-               FD_ZERO(fds);
-       }
-
-       nets = getbroadcastnets(addrs, sock, inbuf);
-       memset(&baddr, 0, sizeof (baddr));
-       baddr.sin_len = sizeof(struct sockaddr_in);
-       baddr.sin_family = AF_INET;
-       baddr.sin_port = htons(PMAPPORT);
-       baddr.sin_addr.s_addr = htonl(INADDR_ANY);
-       gettimeofday(&t, (struct timezone *)0);
-       msg.rm_xid = xid = (++disrupt) ^ 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.
-        *
-        * XXX This will loop about 5 times the stop. If there are
-        * lots of signals being received by the process it will quit
-        * send them all in one quick burst, not paying attention to
-        * the intended function of sending them slowly over half a
-        * minute or so
-        */
-       for (t.tv_sec = 4; t.tv_sec <= 14; t.tv_sec += 2) {
-               int success = 0;
-               for (i = 0; i < nets; i++) {
-                       baddr.sin_addr = addrs[i];
-                       if (_sendto(sock, outbuf, outlen, 0,
-                               (struct sockaddr *)&baddr,
-                               sizeof (struct sockaddr)) == outlen) {
-                               success++;
-                       }
-               }
-               if (!success) {
-                       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;
-               /* XXX we know the other bits are still clear */
-               FD_SET(sock, fds);
-               tv = t;         /* for _select() that copies back */
-               switch (_select(sock + 1, fds, NULL, NULL, &tv)) {
-
-               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;
-
-               }  /* 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_int32_t))
-                       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 ... */
-               }
-               xdrs->x_op = XDR_FREE;
-               msg.acpted_rply.ar_results.proc = xdr_void;
-               xdr_replymsg(xdrs, &msg);
-               (*xresults)(xdrs, resultsp);
-               xdr_destroy(xdrs);
-               if (done) {
-                       stat = RPC_SUCCESS;
-                       goto done_broad;
-               } else {
-                       goto recv_again;
-               }
-       }
-done_broad:
-       if (fds != &readfds)
-               free(fds);
-       if (sock >= 0)
-               _close(sock);
-       AUTH_DESTROY(unix_auth);
-       return (stat);
-}
-