usr.sbin/rpcbind/rpcb_svc_com.c

   1 /*
   2  * Sun RPC is a product of Sun Microsystems, Inc. and is provided for
   3  * unrestricted use provided that this legend is included on all tape
   4  * media and as a part of the software program in whole or part.  Users
   5  * may copy or modify Sun RPC without charge, but are not authorized
   6  * to license or distribute it to anyone else except as part of a product or
   7  * program developed by the user.
   8  *
   9  * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE
  10  * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR
  11  * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE.
  12  *
  13  * Sun RPC is provided with no support and without any obligation on the
  14  * part of Sun Microsystems, Inc. to assist in its use, correction,
  15  * modification or enhancement.
  16  *
  17  * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE
  18  * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC
  19  * OR ANY PART THEREOF.
  20  *
  21  * In no event will Sun Microsystems, Inc. be liable for any lost revenue
  22  * or profits or other special, indirect and consequential damages, even if
  23  * Sun has been advised of the possibility of such damages.
  24  *
  25  * Sun Microsystems, Inc.
  26  * 2550 Garcia Avenue
  27  * Mountain View, California  94043
  28  *
  29  * @(#)rpcb_svc_com.c   1.18    94/05/02 SMI
  30  * $NetBSD: rpcb_svc_com.c,v 1.9 2002/11/08 00:16:39 fvdl Exp $
  31  * $FreeBSD: src/usr.sbin/rpcbind/rpcb_svc_com.c,v 1.12 2007/11/07 10:53:39 kevlo Exp $
  32  */
  33 /*
  34  * Copyright (c) 1986 - 1991 by Sun Microsystems, Inc.
  35  */
  36
  37 /*
  38  * rpcb_svc_com.c
  39  * The commom server procedure for the rpcbind.
  40  */
  41
  42 #include <sys/types.h>
  43 #include <sys/stat.h>
  44 #include <sys/param.h>
  45 #include <sys/poll.h>
  46 #include <sys/socket.h>
  47 #include <rpc/rpc.h>
  48 #include <rpc/rpcb_prot.h>
  49 #include <rpc/svc_dg.h>
  50 #include <netconfig.h>
  51 #include <errno.h>
  52 #include <syslog.h>
  53 #include <unistd.h>
  54 #include <stdio.h>
  55 #ifdef PORTMAP
  56 #include <netinet/in.h>
  57 #include <rpc/pmap_prot.h>
  58 #endif /* PORTMAP */
  59 #include <string.h>
  60 #include <stdlib.h>
  61
  62 #include "rpcbind.h"
  63
  64 #define RPC_BUF_MAX     65536   /* can be raised if required */
  65
  66 static char *nullstring = "";
  67 static int rpcb_rmtcalls;
  68
  69 struct rmtcallfd_list {
  70         int fd;
  71         SVCXPRT *xprt;
  72         char *netid;
  73         struct rmtcallfd_list *next;
  74 };
  75
  76 #define NFORWARD        64
  77 #define MAXTIME_OFF     300     /* 5 minutes */
  78
  79 struct finfo {
  80         int             flag;
  81 #define FINFO_ACTIVE    0x1
  82         u_int32_t       caller_xid;
  83         struct netbuf   *caller_addr;
  84         u_int32_t       forward_xid;
  85         int             forward_fd;
  86         char            *uaddr;
  87         rpcproc_t       reply_type;
  88         rpcvers_t       versnum;
  89         time_t          time;
  90 };
  91 static struct finfo     FINFO[NFORWARD];
  92
  93
  94 static bool_t           xdr_encap_parms(XDR *, struct encap_parms *);
  95 static bool_t           xdr_rmtcall_args(XDR *, struct r_rmtcall_args *);
  96 static bool_t           xdr_rmtcall_result(XDR *, struct r_rmtcall_args *);
  97 static bool_t           xdr_opaque_parms(XDR *, struct r_rmtcall_args *);
  98 static int              find_rmtcallfd_by_netid(char *);
  99 static SVCXPRT          *find_rmtcallxprt_by_fd(int);
 100 static int              forward_register(u_int32_t, struct netbuf *, int,
 101                                          char *, rpcproc_t, rpcvers_t,
 102                                          u_int32_t *);
 103 static struct finfo     *forward_find(u_int32_t);
 104 static int              free_slot_by_xid(u_int32_t);
 105 static int              free_slot_by_index(int);
 106 static int              netbufcmp(struct netbuf *, struct netbuf *);
 107 static struct netbuf    *netbufdup(struct netbuf *);
 108 static void             netbuffree(struct netbuf *);
 109 static int              check_rmtcalls(struct pollfd *, int);
 110 static void             xprt_set_caller(SVCXPRT *, struct finfo *);
 111 static void             send_svcsyserr(SVCXPRT *, struct finfo *);
 112 static void             handle_reply(int, SVCXPRT *);
 113 static void             find_versions(rpcprog_t, char *, rpcvers_t *,
 114                                       rpcvers_t *);
 115 static rpcblist_ptr     find_service(rpcprog_t, rpcvers_t, char *);
 116 static char             *getowner(SVCXPRT *, char *, size_t);
 117 static int              add_pmaplist(RPCB *);
 118 static int              del_pmaplist(RPCB *);
 119
 120 /*
 121  * Set a mapping of program, version, netid
 122  */
 123 /* ARGSUSED */
 124 void *
 125 rpcbproc_set_com(void *arg, struct svc_req *rqstp __unused, SVCXPRT *transp,
 126                  rpcvers_t rpcbversnum)
 127 {
 128         RPCB *regp = (RPCB *)arg;
 129         static bool_t ans;
 130         char owner[64];
 131
 132 #ifdef RPCBIND_DEBUG
 133         if (debugging)
 134                 fprintf(stderr, "RPCB_SET request for (%lu, %lu, %s, %s) : ",
 135                     (unsigned long)regp->r_prog, (unsigned long)regp->r_vers,
 136                     regp->r_netid, regp->r_addr);
 137 #endif
 138         ans = map_set(regp, getowner(transp, owner, sizeof owner));
 139 #ifdef RPCBIND_DEBUG
 140         if (debugging)
 141                 fprintf(stderr, "%s\n", ans == TRUE ? "succeeded" : "failed");
 142 #endif
 143         /* XXX: should have used some defined constant here */
 144         rpcbs_set(rpcbversnum - 2, ans);
 145         return (void *)&ans;
 146 }
 147
 148 bool_t
 149 map_set(RPCB *regp, char *owner)
 150 {
 151         RPCB reg, *a;
 152         rpcblist_ptr rbl, fnd;
 153
 154         reg = *regp;
 155         /*
 156          * check to see if already used
 157          * find_service returns a hit even if
 158          * the versions don't match, so check for it
 159          */
 160         fnd = find_service(reg.r_prog, reg.r_vers, reg.r_netid);
 161         if (fnd && (fnd->rpcb_map.r_vers == reg.r_vers)) {
 162                 if (!strcmp(fnd->rpcb_map.r_addr, reg.r_addr))
 163                         /*
 164                          * if these match then it is already
 165                          * registered so just say "OK".
 166                          */
 167                         return (TRUE);
 168                 else
 169                         return (FALSE);
 170         }
 171         /*
 172          * add to the end of the list
 173          */
 174         rbl = malloc(sizeof (RPCBLIST));
 175         if (rbl == NULL)
 176                 return (FALSE);
 177         a = &(rbl->rpcb_map);
 178         a->r_prog = reg.r_prog;
 179         a->r_vers = reg.r_vers;
 180         a->r_netid = strdup(reg.r_netid);
 181         a->r_addr = strdup(reg.r_addr);
 182         a->r_owner = strdup(owner);
 183         if (!a->r_addr || !a->r_netid || !a->r_owner) {
 184                 if (a->r_netid)
 185                         free(a->r_netid);
 186                 if (a->r_addr)
 187                         free(a->r_addr);
 188                 if (a->r_owner)
 189                         free(a->r_owner);
 190                 free(rbl);
 191                 return (FALSE);
 192         }
 193         rbl->rpcb_next = (rpcblist_ptr)NULL;
 194         if (list_rbl == NULL) {
 195                 list_rbl = rbl;
 196         } else {
 197                 for (fnd = list_rbl; fnd->rpcb_next;
 198                         fnd = fnd->rpcb_next)
 199                         ;
 200                 fnd->rpcb_next = rbl;
 201         }
 202 #ifdef PORTMAP
 203         add_pmaplist(regp);
 204 #endif
 205         return (TRUE);
 206 }
 207
 208 /*
 209  * Unset a mapping of program, version, netid
 210  */
 211 /* ARGSUSED */
 212 void *
 213 rpcbproc_unset_com(void *arg, struct svc_req *rqstp __unused, SVCXPRT *transp,
 214                    rpcvers_t rpcbversnum)
 215 {
 216         RPCB *regp = (RPCB *)arg;
 217         static bool_t ans;
 218         char owner[64];
 219
 220 #ifdef RPCBIND_DEBUG
 221         if (debugging)
 222                 fprintf(stderr, "RPCB_UNSET request for (%lu, %lu, %s) : ",
 223                     (unsigned long)regp->r_prog, (unsigned long)regp->r_vers,
 224                     regp->r_netid);
 225 #endif
 226         ans = map_unset(regp, getowner(transp, owner, sizeof owner));
 227 #ifdef RPCBIND_DEBUG
 228         if (debugging)
 229                 fprintf(stderr, "%s\n", ans == TRUE ? "succeeded" : "failed");
 230 #endif
 231         /* XXX: should have used some defined constant here */
 232         rpcbs_unset(rpcbversnum - 2, ans);
 233         return (void *)&ans;
 234 }
 235
 236 bool_t
 237 map_unset(RPCB *regp, char *owner)
 238 {
 239         int ans = 0;
 240         rpcblist_ptr rbl, prev, tmp;
 241
 242         if (owner == NULL)
 243                 return (0);
 244
 245         for (prev = NULL, rbl = list_rbl; rbl; /* cstyle */) {
 246                 if ((rbl->rpcb_map.r_prog != regp->r_prog) ||
 247                         (rbl->rpcb_map.r_vers != regp->r_vers) ||
 248                         (regp->r_netid[0] && strcasecmp(regp->r_netid,
 249                                 rbl->rpcb_map.r_netid))) {
 250                         /* both rbl & prev move forwards */
 251                         prev = rbl;
 252                         rbl = rbl->rpcb_next;
 253                         continue;
 254                 }
 255                 /*
 256                  * Check whether appropriate uid. Unset only
 257                  * if superuser or the owner itself.
 258                  */
 259                 if (strcmp(owner, "superuser") &&
 260                         strcmp(rbl->rpcb_map.r_owner, owner))
 261                         return (0);
 262                 /* found it; rbl moves forward, prev stays */
 263                 ans = 1;
 264                 tmp = rbl;
 265                 rbl = rbl->rpcb_next;
 266                 if (prev == NULL)
 267                         list_rbl = rbl;
 268                 else
 269                         prev->rpcb_next = rbl;
 270                 free(tmp->rpcb_map.r_addr);
 271                 free(tmp->rpcb_map.r_netid);
 272                 free(tmp->rpcb_map.r_owner);
 273                 free(tmp);
 274         }
 275 #ifdef PORTMAP
 276         if (ans)
 277                 del_pmaplist(regp);
 278 #endif
 279         /*
 280          * We return 1 either when the entry was not there or it
 281          * was able to unset it.  It can come to this point only if
 282          * atleast one of the conditions is true.
 283          */
 284         return (1);
 285 }
 286
 287 void
 288 delete_prog(unsigned int prog)
 289 {
 290         RPCB reg;
 291         rpcblist_ptr rbl;
 292
 293         for (rbl = list_rbl; rbl != NULL; rbl = rbl->rpcb_next) {
 294                 if ((rbl->rpcb_map.r_prog != prog))
 295                         continue;
 296                 if (is_bound(rbl->rpcb_map.r_netid, rbl->rpcb_map.r_addr))
 297                         continue;
 298                 reg.r_prog = rbl->rpcb_map.r_prog;
 299                 reg.r_vers = rbl->rpcb_map.r_vers;
 300                 reg.r_netid = strdup(rbl->rpcb_map.r_netid);
 301                 map_unset(&reg, "superuser");
 302                 free(reg.r_netid);
 303         }
 304 }
 305
 306 void *
 307 rpcbproc_getaddr_com(RPCB *regp, struct svc_req *rqstp __unused,
 308                      SVCXPRT *transp, rpcvers_t rpcbversnum, rpcvers_t verstype)
 309 {
 310         static char *uaddr;
 311         char *saddr = NULL;
 312         rpcblist_ptr fnd;
 313
 314         if (uaddr != NULL && uaddr != nullstring) {
 315                 free(uaddr);
 316                 uaddr = NULL;
 317         }
 318         fnd = find_service(regp->r_prog, regp->r_vers, transp->xp_netid);
 319         if (fnd && ((verstype == RPCB_ALLVERS) ||
 320                     (regp->r_vers == fnd->rpcb_map.r_vers))) {
 321                 if (*(regp->r_addr) != '\0') {  /* may contain a hint about */
 322                         saddr = regp->r_addr;   /* the interface that we    */
 323                 }                               /* should use */
 324                 if (!(uaddr = mergeaddr(transp, transp->xp_netid,
 325                                 fnd->rpcb_map.r_addr, saddr))) {
 326                         /* Try whatever we have */
 327                         uaddr = strdup(fnd->rpcb_map.r_addr);
 328                 } else if (!uaddr[0]) {
 329                         /*
 330                          * The server died.  Unset all versions of this prog.
 331                          */
 332                         delete_prog(regp->r_prog);
 333                         uaddr = nullstring;
 334                 }
 335         } else {
 336                 uaddr = nullstring;
 337         }
 338 #ifdef RPCBIND_DEBUG
 339         if (debugging)
 340                 fprintf(stderr, "getaddr: %s\n", uaddr);
 341 #endif
 342         /* XXX: should have used some defined constant here */
 343         rpcbs_getaddr(rpcbversnum - 2, regp->r_prog, regp->r_vers,
 344                 transp->xp_netid, uaddr);
 345         return (void *)&uaddr;
 346 }
 347
 348 /* ARGSUSED */
 349 void *
 350 rpcbproc_gettime_com(void *arg __unused, struct svc_req *rqstp __unused,
 351                      SVCXPRT *transp __unused, rpcvers_t rpcbversnum __unused)
 352 {
 353         static time_t curtime;
 354
 355         time(&curtime);
 356         return (void *)&curtime;
 357 }
 358
 359 /*
 360  * Convert uaddr to taddr. Should be used only by
 361  * local servers/clients. (kernel level stuff only)
 362  */
 363 /* ARGSUSED */
 364 void *
 365 rpcbproc_uaddr2taddr_com(void *arg, struct svc_req *rqstp __unused,
 366                          SVCXPRT *transp, rpcvers_t rpcbversnum __unused)
 367 {
 368         char **uaddrp = (char **)arg;
 369         struct netconfig *nconf;
 370         static struct netbuf nbuf;
 371         static struct netbuf *taddr;
 372
 373         if (taddr) {
 374                 free(taddr->buf);
 375                 free(taddr);
 376                 taddr = NULL;
 377         }
 378         if (((nconf = rpcbind_get_conf(transp->xp_netid)) == NULL) ||
 379             ((taddr = uaddr2taddr(nconf, *uaddrp)) == NULL)) {
 380                 memset((char *)&nbuf, 0, sizeof (struct netbuf));
 381                 return (void *)&nbuf;
 382         }
 383         return (void *)taddr;
 384 }
 385
 386 /*
 387  * Convert taddr to uaddr. Should be used only by
 388  * local servers/clients. (kernel level stuff only)
 389  */
 390 /* ARGSUSED */
 391 void *
 392 rpcbproc_taddr2uaddr_com(void *arg, struct svc_req *rqstp __unused,
 393                          SVCXPRT *transp, rpcvers_t rpcbversnum __unused)
 394 {
 395         struct netbuf *taddr = (struct netbuf *)arg;
 396         static char *uaddr;
 397         struct netconfig *nconf;
 398
 399 #ifdef CHEW_FDS
 400         int fd;
 401
 402         if ((fd = open("/dev/null", O_RDONLY)) == -1) {
 403                 uaddr = (char *)strerror(errno);
 404                 return (&uaddr);
 405         }
 406 #endif /* CHEW_FDS */
 407         if (uaddr != NULL && uaddr != nullstring) {
 408                 free(uaddr);
 409                 uaddr = NULL;
 410         }
 411         if (((nconf = rpcbind_get_conf(transp->xp_netid)) == NULL) ||
 412                 ((uaddr = taddr2uaddr(nconf, taddr)) == NULL)) {
 413                 uaddr = nullstring;
 414         }
 415         return (void *)&uaddr;
 416 }
 417
 418
 419 static bool_t
 420 xdr_encap_parms(XDR *xdrs, struct encap_parms *epp)
 421 {
 422         return (xdr_bytes(xdrs, &(epp->args), (u_int *) &(epp->arglen), ~0));
 423 }
 424
 425 /*
 426  * XDR remote call arguments.  It ignores the address part.
 427  * written for XDR_DECODE direction only
 428  */
 429 static bool_t
 430 xdr_rmtcall_args(XDR *xdrs, struct r_rmtcall_args *cap)
 431 {
 432         /* does not get the address or the arguments */
 433         if (xdr_u_int32_t(xdrs, &(cap->rmt_prog)) &&
 434             xdr_u_int32_t(xdrs, &(cap->rmt_vers)) &&
 435             xdr_u_int32_t(xdrs, &(cap->rmt_proc))) {
 436                 return (xdr_encap_parms(xdrs, &(cap->rmt_args)));
 437         }
 438         return (FALSE);
 439 }
 440
 441 /*
 442  * XDR remote call results along with the address.  Ignore
 443  * program number, version  number and proc number.
 444  * Written for XDR_ENCODE direction only.
 445  */
 446 static bool_t
 447 xdr_rmtcall_result(XDR *xdrs, struct r_rmtcall_args *cap)
 448 {
 449         bool_t result;
 450
 451 #ifdef PORTMAP
 452         if (cap->rmt_localvers == PMAPVERS) {
 453                 int h1, h2, h3, h4, p1, p2;
 454                 u_long port;
 455
 456                 /* interpret the universal address for TCP/IP */
 457                 if (sscanf(cap->rmt_uaddr, "%d.%d.%d.%d.%d.%d",
 458                         &h1, &h2, &h3, &h4, &p1, &p2) != 6)
 459                         return (FALSE);
 460                 port = ((p1 & 0xff) << 8) + (p2 & 0xff);
 461                 result = xdr_u_long(xdrs, &port);
 462         } else
 463 #endif
 464                 if ((cap->rmt_localvers == RPCBVERS) ||
 465                     (cap->rmt_localvers == RPCBVERS4)) {
 466                 result = xdr_wrapstring(xdrs, &(cap->rmt_uaddr));
 467         } else {
 468                 return (FALSE);
 469         }
 470         if (result == TRUE)
 471                 return (xdr_encap_parms(xdrs, &(cap->rmt_args)));
 472         return (FALSE);
 473 }
 474
 475 /*
 476  * only worries about the struct encap_parms part of struct r_rmtcall_args.
 477  * The arglen must already be set!!
 478  */
 479 static bool_t
 480 xdr_opaque_parms(XDR *xdrs, struct r_rmtcall_args *cap)
 481 {
 482         return (xdr_opaque(xdrs, cap->rmt_args.args, cap->rmt_args.arglen));
 483 }
 484
 485 static struct rmtcallfd_list *rmthead;
 486 static struct rmtcallfd_list *rmttail;
 487
 488 int
 489 create_rmtcall_fd(struct netconfig *nconf)
 490 {
 491         int fd;
 492         struct rmtcallfd_list *rmt;
 493         SVCXPRT *xprt;
 494
 495         if ((fd = __rpc_nconf2fd(nconf)) == -1) {
 496                 if (debugging)
 497                         fprintf(stderr,
 498         "create_rmtcall_fd: couldn't open \"%s\" (errno %d)\n",
 499                         nconf->nc_device, errno);
 500                 return (-1);
 501         }
 502         xprt = svc_tli_create(fd, 0, (struct t_bind *) 0, 0, 0);
 503         if (xprt == NULL) {
 504                 if (debugging)
 505                         fprintf(stderr,
 506                                 "create_rmtcall_fd: svc_tli_create failed\n");
 507                 return (-1);
 508         }
 509         rmt = malloc(sizeof (struct rmtcallfd_list));
 510         if (rmt == NULL) {
 511                 syslog(LOG_ERR, "create_rmtcall_fd: no memory!");
 512                 return (-1);
 513         }
 514         rmt->xprt = xprt;
 515         rmt->netid = strdup(nconf->nc_netid);
 516         xprt->xp_netid = rmt->netid;
 517         rmt->fd = fd;
 518         rmt->next = NULL;
 519         if (rmthead == NULL) {
 520                 rmthead = rmt;
 521                 rmttail = rmt;
 522         } else {
 523                 rmttail->next = rmt;
 524                 rmttail = rmt;
 525         }
 526         /* XXX not threadsafe */
 527         if (fd > svc_maxfd)
 528                 svc_maxfd = fd;
 529         FD_SET(fd, &svc_fdset);
 530         return (fd);
 531 }
 532
 533 static int
 534 find_rmtcallfd_by_netid(char *netid)
 535 {
 536         struct rmtcallfd_list *rmt;
 537
 538         for (rmt = rmthead; rmt != NULL; rmt = rmt->next) {
 539                 if (strcmp(netid, rmt->netid) == 0) {
 540                         return (rmt->fd);
 541                 }
 542         }
 543         return (-1);
 544 }
 545
 546 static SVCXPRT *
 547 find_rmtcallxprt_by_fd(int fd)
 548 {
 549         struct rmtcallfd_list *rmt;
 550
 551         for (rmt = rmthead; rmt != NULL; rmt = rmt->next) {
 552                 if (fd == rmt->fd) {
 553                         return (rmt->xprt);
 554                 }
 555         }
 556         return (NULL);
 557 }
 558
 559
 560 /*
 561  * Call a remote procedure service.  This procedure is very quiet when things
 562  * go wrong.  The proc is written to support broadcast rpc.  In the broadcast
 563  * case, a machine should shut-up instead of complain, lest the requestor be
 564  * overrun with complaints at the expense of not hearing a valid reply.
 565  * When receiving a request and verifying that the service exists, we
 566  *
 567  *      receive the request
 568  *
 569  *      open a new TLI endpoint on the same transport on which we received
 570  *      the original request
 571  *
 572  *      remember the original request's XID (which requires knowing the format
 573  *      of the svc_dg_data structure)
 574  *
 575  *      forward the request, with a new XID, to the requested service,
 576  *      remembering the XID used to send this request (for later use in
 577  *      reassociating the answer with the original request), the requestor's
 578  *      address, the file descriptor on which the forwarded request is
 579  *      made and the service's address.
 580  *
 581  *      mark the file descriptor on which we anticipate receiving a reply from
 582  *      the service and one to select for in our private svc_run procedure
 583  *
 584  * At some time in the future, a reply will be received from the service to
 585  * which we forwarded the request.  At that time, we detect that the socket
 586  * used was for forwarding (by looking through the finfo structures to see
 587  * whether the fd corresponds to one of those) and call handle_reply() to
 588  *
 589  *      receive the reply
 590  *
 591  *      bundle the reply, along with the service's universal address
 592  *
 593  *      create a SVCXPRT structure and use a version of svc_sendreply
 594  *      that allows us to specify the reply XID and destination, send the reply
 595  *      to the original requestor.
 596  */
 597
 598 void
 599 rpcbproc_callit_com(struct svc_req *rqstp, SVCXPRT *transp,
 600                     rpcproc_t reply_type, rpcvers_t versnum)
 601 {
 602         rpcblist_ptr rbl;
 603         struct netconfig *nconf;
 604         struct netbuf *caller;
 605         struct r_rmtcall_args a;
 606         char *buf_alloc = NULL, *outbufp;
 607         char *outbuf_alloc = NULL;
 608         char buf[RPC_BUF_MAX], outbuf[RPC_BUF_MAX];
 609         struct netbuf *na = (struct netbuf *) NULL;
 610         struct rpc_msg call_msg;
 611         int outlen;
 612         u_int sendsz;
 613         XDR outxdr;
 614         AUTH *auth;
 615         int fd = -1;
 616         char *uaddr, *m_uaddr = NULL, *local_uaddr = NULL;
 617         u_int32_t *xidp;
 618         struct __rpc_sockinfo si;
 619         struct sockaddr *localsa;
 620         struct netbuf tbuf;
 621
 622         if (!__rpc_fd2sockinfo(transp->xp_fd, &si)) {
 623                 if (reply_type == RPCBPROC_INDIRECT)
 624                         svcerr_systemerr(transp);
 625                 return;
 626         }
 627         if (si.si_socktype != SOCK_DGRAM)
 628                 return; /* Only datagram type accepted */
 629         sendsz = __rpc_get_t_size(si.si_af, si.si_proto, UDPMSGSIZE);
 630         if (sendsz == 0) {      /* data transfer not supported */
 631                 if (reply_type == RPCBPROC_INDIRECT)
 632                         svcerr_systemerr(transp);
 633                 return;
 634         }
 635         /*
 636          * Should be multiple of 4 for XDR.
 637          */
 638         sendsz = ((sendsz + 3) / 4) * 4;
 639         if (sendsz > RPC_BUF_MAX) {
 640 #ifdef  notyet
 641                 buf_alloc = alloca(sendsz);             /* not in IDR2? */
 642 #else
 643                 buf_alloc = malloc(sendsz);
 644 #endif  /* notyet */
 645                 if (buf_alloc == NULL) {
 646                         if (debugging)
 647                                 fprintf(stderr,
 648                                         "rpcbproc_callit_com:  No Memory!\n");
 649                         if (reply_type == RPCBPROC_INDIRECT)
 650                                 svcerr_systemerr(transp);
 651                         return;
 652                 }
 653                 a.rmt_args.args = buf_alloc;
 654         } else {
 655                 a.rmt_args.args = buf;
 656         }
 657
 658         call_msg.rm_xid = 0;    /* For error checking purposes */
 659         if (!svc_getargs(transp, (xdrproc_t) xdr_rmtcall_args, (char *) &a)) {
 660                 if (reply_type == RPCBPROC_INDIRECT)
 661                         svcerr_decode(transp);
 662                 if (debugging)
 663                         fprintf(stderr,
 664                         "rpcbproc_callit_com:  svc_getargs failed\n");
 665                 goto error;
 666         }
 667
 668         if (!check_callit(transp, &a, versnum)) {
 669                 svcerr_weakauth(transp);
 670                 goto error;
 671         }
 672
 673         caller = svc_getrpccaller(transp);
 674 #ifdef RPCBIND_DEBUG
 675         if (debugging) {
 676                 uaddr = taddr2uaddr(rpcbind_get_conf(transp->xp_netid), caller);
 677                 fprintf(stderr, "%s %s req for (%lu, %lu, %lu, %s) from %s : ",
 678                         versnum == PMAPVERS ? "pmap_rmtcall" :
 679                         versnum == RPCBVERS ? "rpcb_rmtcall" :
 680                         versnum == RPCBVERS4 ? "rpcb_indirect" : "unknown",
 681                         reply_type == RPCBPROC_INDIRECT ? "indirect" : "callit",
 682                         (unsigned long)a.rmt_prog, (unsigned long)a.rmt_vers,
 683                         (unsigned long)a.rmt_proc, transp->xp_netid,
 684                         uaddr ? uaddr : "unknown");
 685                 if (uaddr)
 686                         free(uaddr);
 687         }
 688 #endif
 689
 690         rbl = find_service(a.rmt_prog, a.rmt_vers, transp->xp_netid);
 691
 692         rpcbs_rmtcall(versnum - 2, reply_type, a.rmt_prog, a.rmt_vers,
 693                         a.rmt_proc, transp->xp_netid, rbl);
 694
 695         if (rbl == (rpcblist_ptr)NULL) {
 696 #ifdef RPCBIND_DEBUG
 697                 if (debugging)
 698                         fprintf(stderr, "not found\n");
 699 #endif
 700                 if (reply_type == RPCBPROC_INDIRECT)
 701                         svcerr_noprog(transp);
 702                 goto error;
 703         }
 704         if (rbl->rpcb_map.r_vers != a.rmt_vers) {
 705                 if (reply_type == RPCBPROC_INDIRECT) {
 706                         rpcvers_t vers_low, vers_high;
 707
 708                         find_versions(a.rmt_prog, transp->xp_netid,
 709                                 &vers_low, &vers_high);
 710                         svcerr_progvers(transp, vers_low, vers_high);
 711                 }
 712                 goto error;
 713         }
 714
 715 #ifdef RPCBIND_DEBUG
 716         if (debugging)
 717                 fprintf(stderr, "found at uaddr %s\n", rbl->rpcb_map.r_addr);
 718 #endif
 719         /*
 720          *      Check whether this entry is valid and a server is present
 721          *      Mergeaddr() returns NULL if no such entry is present, and
 722          *      returns "" if the entry was present but the server is not
 723          *      present (i.e., it crashed).
 724          */
 725         if (reply_type == RPCBPROC_INDIRECT) {
 726                 uaddr = mergeaddr(transp, transp->xp_netid,
 727                         rbl->rpcb_map.r_addr, NULL);
 728                 if (uaddr == NULL || uaddr[0] == '\0') {
 729                         svcerr_noprog(transp);
 730                         if (uaddr != NULL)
 731                                 free(uaddr);
 732                         goto error;
 733                 }
 734                 free(uaddr);
 735         }
 736         nconf = rpcbind_get_conf(transp->xp_netid);
 737         if (nconf == NULL) {
 738                 if (reply_type == RPCBPROC_INDIRECT)
 739                         svcerr_systemerr(transp);
 740                 if (debugging)
 741                         fprintf(stderr,
 742                         "rpcbproc_callit_com:  rpcbind_get_conf failed\n");
 743                 goto error;
 744         }
 745         localsa = local_sa(((struct sockaddr *)caller->buf)->sa_family);
 746         if (localsa == NULL) {
 747                 if (debugging)
 748                         fprintf(stderr,
 749                         "rpcbproc_callit_com: no local address\n");
 750                 goto error;
 751         }
 752         tbuf.len = tbuf.maxlen = localsa->sa_len;
 753         tbuf.buf = localsa;
 754         local_uaddr =
 755             addrmerge(&tbuf, rbl->rpcb_map.r_addr, NULL, nconf->nc_netid);
 756         m_uaddr = addrmerge(caller, rbl->rpcb_map.r_addr, NULL,
 757                         nconf->nc_netid);
 758 #ifdef RPCBIND_DEBUG
 759         if (debugging)
 760                 fprintf(stderr, "merged uaddr %s\n", m_uaddr);
 761 #endif
 762         if ((fd = find_rmtcallfd_by_netid(nconf->nc_netid)) == -1) {
 763                 if (reply_type == RPCBPROC_INDIRECT)
 764                         svcerr_systemerr(transp);
 765                 goto error;
 766         }
 767         xidp = __rpcb_get_dg_xidp(transp);
 768         switch (forward_register(*xidp, caller, fd, m_uaddr, reply_type,
 769             versnum, &call_msg.rm_xid)) {
 770         case 1:
 771                 /* Success; forward_register() will free m_uaddr for us. */
 772                 m_uaddr = NULL;
 773                 break;
 774         case 0:
 775                 /*
 776                  * A duplicate request for the slow server.  Let's not
 777                  * beat on it any more.
 778                  */
 779                 if (debugging)
 780                         fprintf(stderr,
 781                         "rpcbproc_callit_com:  duplicate request\n");
 782                 goto error;
 783         case -1:
 784                 /*  forward_register failed.  Perhaps no memory. */
 785                 if (debugging)
 786                         fprintf(stderr,
 787                         "rpcbproc_callit_com:  forward_register failed\n");
 788                 goto error;
 789         }
 790
 791 #ifdef DEBUG_RMTCALL
 792         if (debugging)
 793                 fprintf(stderr,
 794                         "rpcbproc_callit_com:  original XID %x, new XID %x\n",
 795                                 *xidp, call_msg.rm_xid);
 796 #endif
 797         call_msg.rm_direction = CALL;
 798         call_msg.rm_call.cb_rpcvers = RPC_MSG_VERSION;
 799         call_msg.rm_call.cb_prog = a.rmt_prog;
 800         call_msg.rm_call.cb_vers = a.rmt_vers;
 801         if (sendsz > RPC_BUF_MAX) {
 802 #ifdef  notyet
 803                 outbuf_alloc = alloca(sendsz);  /* not in IDR2? */
 804 #else
 805                 outbuf_alloc = malloc(sendsz);
 806 #endif  /* notyet */
 807                 if (outbuf_alloc == NULL) {
 808                         if (reply_type == RPCBPROC_INDIRECT)
 809                                 svcerr_systemerr(transp);
 810                         if (debugging)
 811                                 fprintf(stderr,
 812                                 "rpcbproc_callit_com:  No memory!\n");
 813                         goto error;
 814                 }
 815                 xdrmem_create(&outxdr, outbuf_alloc, sendsz, XDR_ENCODE);
 816         } else {
 817                 xdrmem_create(&outxdr, outbuf, sendsz, XDR_ENCODE);
 818         }
 819         if (!xdr_callhdr(&outxdr, &call_msg)) {
 820                 if (reply_type == RPCBPROC_INDIRECT)
 821                         svcerr_systemerr(transp);
 822                 if (debugging)
 823                         fprintf(stderr,
 824                         "rpcbproc_callit_com:  xdr_callhdr failed\n");
 825                 goto error;
 826         }
 827         if (!xdr_u_int32_t(&outxdr, &(a.rmt_proc))) {
 828                 if (reply_type == RPCBPROC_INDIRECT)
 829                         svcerr_systemerr(transp);
 830                 if (debugging)
 831                         fprintf(stderr,
 832                         "rpcbproc_callit_com:  xdr_u_long failed\n");
 833                 goto error;
 834         }
 835
 836         if (rqstp->rq_cred.oa_flavor == AUTH_NULL) {
 837                 auth = authnone_create();
 838         } else if (rqstp->rq_cred.oa_flavor == AUTH_SYS) {
 839                 struct authunix_parms *au;
 840
 841                 au = (struct authunix_parms *)rqstp->rq_clntcred;
 842                 auth = authunix_create(au->aup_machname,
 843                                 au->aup_uid, au->aup_gid,
 844                                 au->aup_len, au->aup_gids);
 845                 if (auth == NULL) /* fall back */
 846                         auth = authnone_create();
 847         } else {
 848                 /* we do not support any other authentication scheme */
 849                 if (debugging)
 850                         fprintf(stderr,
 851 "rpcbproc_callit_com:  oa_flavor != AUTH_NONE and oa_flavor != AUTH_SYS\n");
 852                 if (reply_type == RPCBPROC_INDIRECT)
 853                         svcerr_weakauth(transp); /* XXX too strong.. */
 854                 goto error;
 855         }
 856         if (auth == NULL) {
 857                 if (reply_type == RPCBPROC_INDIRECT)
 858                         svcerr_systemerr(transp);
 859                 if (debugging)
 860                         fprintf(stderr,
 861                 "rpcbproc_callit_com:  authwhatever_create returned NULL\n");
 862                 goto error;
 863         }
 864         if (!AUTH_MARSHALL(auth, &outxdr)) {
 865                 if (reply_type == RPCBPROC_INDIRECT)
 866                         svcerr_systemerr(transp);
 867                 AUTH_DESTROY(auth);
 868                 if (debugging)
 869                         fprintf(stderr,
 870                 "rpcbproc_callit_com:  AUTH_MARSHALL failed\n");
 871                 goto error;
 872         }
 873         AUTH_DESTROY(auth);
 874         if (!xdr_opaque_parms(&outxdr, &a)) {
 875                 if (reply_type == RPCBPROC_INDIRECT)
 876                         svcerr_systemerr(transp);
 877                 if (debugging)
 878                         fprintf(stderr,
 879                 "rpcbproc_callit_com:  xdr_opaque_parms failed\n");
 880                 goto error;
 881         }
 882         outlen = (int) XDR_GETPOS(&outxdr);
 883         if (outbuf_alloc)
 884                 outbufp = outbuf_alloc;
 885         else
 886                 outbufp = outbuf;
 887
 888         na = uaddr2taddr(nconf, local_uaddr);
 889         if (!na) {
 890                 if (reply_type == RPCBPROC_INDIRECT)
 891                         svcerr_systemerr(transp);
 892                 goto error;
 893         }
 894
 895         if (sendto(fd, outbufp, outlen, 0, (struct sockaddr *)na->buf, na->len)
 896             != outlen) {
 897                 if (debugging)
 898                         fprintf(stderr,
 899         "rpcbproc_callit_com:  sendto failed:  errno %d\n", errno);
 900                 if (reply_type == RPCBPROC_INDIRECT)
 901                         svcerr_systemerr(transp);
 902                 goto error;
 903         }
 904         goto out;
 905
 906 error:
 907         if (call_msg.rm_xid != 0)
 908                 free_slot_by_xid(call_msg.rm_xid);
 909 out:
 910         if (local_uaddr)
 911                 free(local_uaddr);
 912         if (buf_alloc)
 913                 free(buf_alloc);
 914         if (outbuf_alloc)
 915                 free(outbuf_alloc);
 916         if (na) {
 917                 free(na->buf);
 918                 free(na);
 919         }
 920         if (m_uaddr != NULL)
 921                 free(m_uaddr);
 922 }
 923
 924 /*
 925  * Makes an entry into the FIFO for the given request.
 926  * Returns 1 on success, 0 if this is a duplicate request, or -1 on error.
 927  * *callxidp is set to the xid of the call.
 928  */
 929 static int
 930 forward_register(u_int32_t caller_xid, struct netbuf *caller_addr,
 931                  int forward_fd, char *uaddr, rpcproc_t reply_type,
 932                  rpcvers_t versnum, u_int32_t *callxidp)
 933 {
 934         int             i;
 935         int             j = 0;
 936         time_t          min_time, time_now;
 937         static u_int32_t        lastxid;
 938         int             entry = -1;
 939
 940         min_time = FINFO[0].time;
 941         time_now = time(NULL);
 942         /* initialization */
 943         if (lastxid == 0)
 944                 lastxid = time_now * NFORWARD;
 945
 946         /*
 947          * Check if it is a duplicate entry. Then,
 948          * try to find an empty slot.  If not available, then
 949          * use the slot with the earliest time.
 950          */
 951         for (i = 0; i < NFORWARD; i++) {
 952                 if (FINFO[i].flag & FINFO_ACTIVE) {
 953                         if ((FINFO[i].caller_xid == caller_xid) &&
 954                             (FINFO[i].reply_type == reply_type) &&
 955                             (FINFO[i].versnum == versnum) &&
 956                             (!netbufcmp(FINFO[i].caller_addr,
 957                                             caller_addr))) {
 958                                 FINFO[i].time = time(NULL);
 959                                 return (0);     /* Duplicate entry */
 960                         } else {
 961                                 /* Should we wait any longer */
 962                                 if ((time_now - FINFO[i].time) > MAXTIME_OFF)
 963                                         free_slot_by_index(i);
 964                         }
 965                 }
 966                 if (entry == -1) {
 967                         if ((FINFO[i].flag & FINFO_ACTIVE) == 0) {
 968                                 entry = i;
 969                         } else if (FINFO[i].time < min_time) {
 970                                 j = i;
 971                                 min_time = FINFO[i].time;
 972                         }
 973                 }
 974         }
 975         if (entry != -1) {
 976                 /* use this empty slot */
 977                 j = entry;
 978         } else {
 979                 free_slot_by_index(j);
 980         }
 981         if ((FINFO[j].caller_addr = netbufdup(caller_addr)) == NULL) {
 982                 return (-1);
 983         }
 984         rpcb_rmtcalls++;        /* no of pending calls */
 985         FINFO[j].flag = FINFO_ACTIVE;
 986         FINFO[j].reply_type = reply_type;
 987         FINFO[j].versnum = versnum;
 988         FINFO[j].time = time_now;
 989         FINFO[j].caller_xid = caller_xid;
 990         FINFO[j].forward_fd = forward_fd;
 991         /*
 992          * Though uaddr is not allocated here, it will still be freed
 993          * from free_slot_*().
 994          */
 995         FINFO[j].uaddr = uaddr;
 996         lastxid = lastxid + NFORWARD;
 997         /* Don't allow a zero xid below. */
 998         if ((u_int32_t)(lastxid + NFORWARD) <= NFORWARD)
 999                 lastxid = NFORWARD;
1000         FINFO[j].forward_xid = lastxid + j;     /* encode slot */
1001         *callxidp = FINFO[j].forward_xid;       /* forward on this xid */
1002         return (1);
1003 }
1004
1005 static struct finfo *
1006 forward_find(u_int32_t reply_xid)
1007 {
1008         int             i;
1009
1010         i = reply_xid % (u_int32_t)NFORWARD;
1011         if ((FINFO[i].flag & FINFO_ACTIVE) &&
1012             (FINFO[i].forward_xid == reply_xid)) {
1013                 return (&FINFO[i]);
1014         }
1015         return (NULL);
1016 }
1017
1018 static int
1019 free_slot_by_xid(u_int32_t xid)
1020 {
1021         int entry;
1022
1023         entry = xid % (u_int32_t)NFORWARD;
1024         return (free_slot_by_index(entry));
1025 }
1026
1027 static int
1028 free_slot_by_index(int index)
1029 {
1030         struct finfo    *fi;
1031
1032         fi = &FINFO[index];
1033         if (fi->flag & FINFO_ACTIVE) {
1034                 netbuffree(fi->caller_addr);
1035                 /* XXX may be too big, but can't access xprt array here */
1036                 if (fi->forward_fd >= svc_maxfd)
1037                         svc_maxfd--;
1038                 free(fi->uaddr);
1039                 fi->flag &= ~FINFO_ACTIVE;
1040                 rpcb_rmtcalls--;
1041                 return (1);
1042         }
1043         return (0);
1044 }
1045
1046 static int
1047 netbufcmp(struct netbuf *n1, struct netbuf *n2)
1048 {
1049         return ((n1->len != n2->len) || memcmp(n1->buf, n2->buf, n1->len));
1050 }
1051
1052 static struct netbuf *
1053 netbufdup(struct netbuf *ap)
1054 {
1055         struct netbuf  *np;
1056
1057         if ((np = malloc(sizeof(struct netbuf))) == NULL)
1058                 return (NULL);
1059         if ((np->buf = malloc(ap->len)) == NULL) {
1060                 free(np);
1061                 return (NULL);
1062         }
1063         np->maxlen = np->len = ap->len;
1064         memcpy(np->buf, ap->buf, ap->len);
1065         return (np);
1066 }
1067
1068 static void
1069 netbuffree(struct netbuf *ap)
1070 {
1071         free(ap->buf);
1072         free(ap);
1073 }
1074
1075
1076 #define MASKVAL (POLLIN | POLLPRI | POLLRDNORM | POLLRDBAND)
1077 extern bool_t __svc_clean_idle(fd_set *, int, bool_t);
1078
1079 void
1080 my_svc_run(void)
1081 {
1082         size_t nfds;
1083         struct pollfd pollfds[FD_SETSIZE];
1084         int poll_ret, check_ret;
1085         int n;
1086 #ifdef SVC_RUN_DEBUG
1087         int i;
1088 #endif
1089         struct pollfd   *p;
1090         fd_set cleanfds;
1091
1092         for (;;) {
1093                 p = pollfds;
1094                 for (n = 0; n <= svc_maxfd; n++) {
1095                         if (FD_ISSET(n, &svc_fdset)) {
1096                                 p->fd = n;
1097                                 p->events = MASKVAL;
1098                                 p++;
1099                         }
1100                 }
1101                 nfds = p - pollfds;
1102                 poll_ret = 0;
1103 #ifdef SVC_RUN_DEBUG
1104                 if (debugging) {
1105                         fprintf(stderr, "polling for read on fd < ");
1106                         for (i = 0, p = pollfds; i < nfds; i++, p++)
1107                                 if (p->events)
1108                                         fprintf(stderr, "%d ", p->fd);
1109                         fprintf(stderr, ">\n");
1110                 }
1111 #endif
1112                 switch (poll_ret = poll(pollfds, nfds, 30 * 1000)) {
1113                 case -1:
1114                         /*
1115                          * We ignore all errors, continuing with the assumption
1116                          * that it was set by the signal handlers (or any
1117                          * other outside event) and not caused by poll().
1118                          */
1119                 case 0:
1120                         cleanfds = svc_fdset;
1121                         __svc_clean_idle(&cleanfds, 30, FALSE);
1122                         continue;
1123                 default:
1124 #ifdef SVC_RUN_DEBUG
1125                         if (debugging) {
1126                                 fprintf(stderr, "poll returned read fds < ");
1127                                 for (i = 0, p = pollfds; i < nfds; i++, p++)
1128                                         if (p->revents)
1129                                                 fprintf(stderr, "%d ", p->fd);
1130                                 fprintf(stderr, ">\n");
1131                         }
1132 #endif
1133                         /*
1134                          * If we found as many replies on callback fds
1135                          * as the number of descriptors selectable which
1136                          * poll() returned, there can be no more so we
1137                          * don't call svc_getreq_poll.  Otherwise, there
1138                          * must be another so we must call svc_getreq_poll.
1139                          */
1140                         if ((check_ret = check_rmtcalls(pollfds, nfds)) ==
1141                             poll_ret)
1142                                 continue;
1143                         svc_getreq_poll(pollfds, poll_ret-check_ret);
1144                 }
1145 #ifdef SVC_RUN_DEBUG
1146                 if (debugging) {
1147                         fprintf(stderr, "svc_maxfd now %u\n", svc_maxfd);
1148                 }
1149 #endif
1150         }
1151 }
1152
1153 static int
1154 check_rmtcalls(struct pollfd *pfds, int nfds)
1155 {
1156         int j, ncallbacks_found = 0, rmtcalls_pending;
1157         SVCXPRT *xprt;
1158
1159         if (rpcb_rmtcalls == 0)
1160                 return (0);
1161
1162         rmtcalls_pending = rpcb_rmtcalls;
1163         for (j = 0; j < nfds; j++) {
1164                 if ((xprt = find_rmtcallxprt_by_fd(pfds[j].fd)) != NULL) {
1165                         if (pfds[j].revents) {
1166                                 ncallbacks_found++;
1167 #ifdef DEBUG_RMTCALL
1168                         if (debugging)
1169                                 fprintf(stderr,
1170 "my_svc_run:  polled on forwarding fd %d, netid %s - calling handle_reply\n",
1171                 pfds[j].fd, xprt->xp_netid);
1172 #endif
1173                                 handle_reply(pfds[j].fd, xprt);
1174                                 pfds[j].revents = 0;
1175                                 if (ncallbacks_found >= rmtcalls_pending) {
1176                                         break;
1177                                 }
1178                         }
1179                 }
1180         }
1181         return (ncallbacks_found);
1182 }
1183
1184 static void
1185 xprt_set_caller(SVCXPRT *xprt, struct finfo *fi)
1186 {
1187         u_int32_t *xidp;
1188
1189         *(svc_getrpccaller(xprt)) = *(fi->caller_addr);
1190         xidp = __rpcb_get_dg_xidp(xprt);
1191         *xidp = fi->caller_xid;
1192 }
1193
1194 /*
1195  * Call svcerr_systemerr() only if RPCBVERS4
1196  */
1197 static void
1198 send_svcsyserr(SVCXPRT *xprt, struct finfo *fi)
1199 {
1200         if (fi->reply_type == RPCBPROC_INDIRECT) {
1201                 xprt_set_caller(xprt, fi);
1202                 svcerr_systemerr(xprt);
1203         }
1204         return;
1205 }
1206
1207 static void
1208 handle_reply(int fd, SVCXPRT *xprt)
1209 {
1210         XDR             reply_xdrs;
1211         struct rpc_msg  reply_msg;
1212         struct rpc_err  reply_error;
1213         char            *buffer;
1214         struct finfo    *fi;
1215         int             inlen, pos, len;
1216         struct r_rmtcall_args a;
1217         struct sockaddr_storage ss;
1218         socklen_t fromlen;
1219 #ifdef SVC_RUN_DEBUG
1220         char *uaddr;
1221 #endif
1222
1223         buffer = malloc(RPC_BUF_MAX);
1224         if (buffer == NULL)
1225                 goto done;
1226
1227         do {
1228                 inlen = recvfrom(fd, buffer, RPC_BUF_MAX, 0,
1229                             (struct sockaddr *)&ss, &fromlen);
1230         } while (inlen < 0 && errno == EINTR);
1231         if (inlen < 0) {
1232                 if (debugging)
1233                         fprintf(stderr,
1234         "handle_reply:  recvfrom returned %d, errno %d\n", inlen, errno);
1235                 goto done;
1236         }
1237
1238         reply_msg.acpted_rply.ar_verf = _null_auth;
1239         reply_msg.acpted_rply.ar_results.where = 0;
1240         reply_msg.acpted_rply.ar_results.proc = (xdrproc_t) xdr_void;
1241
1242         xdrmem_create(&reply_xdrs, buffer, (u_int)inlen, XDR_DECODE);
1243         if (!xdr_replymsg(&reply_xdrs, &reply_msg)) {
1244                 if (debugging)
1245                         fprintf(stderr, "handle_reply:  xdr_replymsg failed\n");
1246                 goto done;
1247         }
1248         fi = forward_find(reply_msg.rm_xid);
1249 #ifdef  SVC_RUN_DEBUG
1250         if (debugging) {
1251                 fprintf(stderr, "handle_reply:  reply xid: %d fi addr: %p\n",
1252                         reply_msg.rm_xid, fi);
1253         }
1254 #endif
1255         if (fi == NULL) {
1256                 goto done;
1257         }
1258         _seterr_reply(&reply_msg, &reply_error);
1259         if (reply_error.re_status != RPC_SUCCESS) {
1260                 if (debugging)
1261                         fprintf(stderr, "handle_reply:  %s\n",
1262                                 clnt_sperrno(reply_error.re_status));
1263                 send_svcsyserr(xprt, fi);
1264                 goto done;
1265         }
1266         pos = XDR_GETPOS(&reply_xdrs);
1267         len = inlen - pos;
1268         a.rmt_args.args = &buffer[pos];
1269         a.rmt_args.arglen = len;
1270         a.rmt_uaddr = fi->uaddr;
1271         a.rmt_localvers = fi->versnum;
1272
1273         xprt_set_caller(xprt, fi);
1274 #ifdef  SVC_RUN_DEBUG
1275         uaddr = taddr2uaddr(rpcbind_get_conf("udp"),
1276                                     svc_getrpccaller(xprt));
1277         if (debugging) {
1278                 fprintf(stderr, "handle_reply:  forwarding address %s to %s\n",
1279                         a.rmt_uaddr, uaddr ? uaddr : "unknown");
1280         }
1281         if (uaddr)
1282                 free(uaddr);
1283 #endif
1284         svc_sendreply(xprt, (xdrproc_t) xdr_rmtcall_result, (char *) &a);
1285 done:
1286         if (buffer)
1287                 free(buffer);
1288
1289         if (reply_msg.rm_xid == 0) {
1290 #ifdef  SVC_RUN_DEBUG
1291         if (debugging) {
1292                 fprintf(stderr, "handle_reply:  NULL xid on exit!\n");
1293         }
1294 #endif
1295         } else
1296                 free_slot_by_xid(reply_msg.rm_xid);
1297         return;
1298 }
1299
1300 static void
1301 find_versions(rpcprog_t prog, char *netid, rpcvers_t *lowvp, rpcvers_t *highvp)
1302 {
1303         rpcblist_ptr rbl;
1304         unsigned int lowv = 0;
1305         unsigned int highv = 0;
1306
1307         for (rbl = list_rbl; rbl != NULL; rbl = rbl->rpcb_next) {
1308                 if ((rbl->rpcb_map.r_prog != prog) ||
1309                     ((rbl->rpcb_map.r_netid != NULL) &&
1310                         (strcasecmp(rbl->rpcb_map.r_netid, netid) != 0)))
1311                         continue;
1312                 if (lowv == 0) {
1313                         highv = rbl->rpcb_map.r_vers;
1314                         lowv = highv;
1315                 } else if (rbl->rpcb_map.r_vers < lowv) {
1316                         lowv = rbl->rpcb_map.r_vers;
1317                 } else if (rbl->rpcb_map.r_vers > highv) {
1318                         highv = rbl->rpcb_map.r_vers;
1319                 }
1320         }
1321         *lowvp = lowv;
1322         *highvp = highv;
1323         return;
1324 }
1325
1326 /*
1327  * returns the item with the given program, version number and netid.
1328  * If that version number is not found, it returns the item with that
1329  * program number, so that address is now returned to the caller. The
1330  * caller when makes a call to this program, version number, the call
1331  * will fail and it will return with PROGVERS_MISMATCH. The user can
1332  * then determine the highest and the lowest version number for this
1333  * program using clnt_geterr() and use those program version numbers.
1334  *
1335  * Returns the RPCBLIST for the given prog, vers and netid
1336  */
1337 static rpcblist_ptr
1338 find_service(rpcprog_t prog, rpcvers_t vers, char *netid)
1339 {
1340         rpcblist_ptr hit = NULL;
1341         rpcblist_ptr rbl;
1342
1343         for (rbl = list_rbl; rbl != NULL; rbl = rbl->rpcb_next) {
1344                 if ((rbl->rpcb_map.r_prog != prog) ||
1345                     ((rbl->rpcb_map.r_netid != NULL) &&
1346                         (strcasecmp(rbl->rpcb_map.r_netid, netid) != 0)))
1347                         continue;
1348                 hit = rbl;
1349                 if (rbl->rpcb_map.r_vers == vers)
1350                         break;
1351         }
1352         return (hit);
1353 }
1354
1355 /*
1356  * Copies the name associated with the uid of the caller and returns
1357  * a pointer to it.  Similar to getwd().
1358  */
1359 static char *
1360 getowner(SVCXPRT *transp, char *owner, size_t ownersize)
1361 {
1362         uid_t uid;
1363
1364         if (__rpc_get_local_uid(transp, &uid) < 0)
1365                 strlcpy(owner, "unknown", ownersize);
1366         else if (uid == 0)
1367                 strlcpy(owner, "superuser", ownersize);
1368         else
1369                 snprintf(owner, ownersize, "%d", uid);
1370
1371         return owner;
1372 }
1373
1374 #ifdef PORTMAP
1375 /*
1376  * Add this to the pmap list only if it is UDP or TCP.
1377  */
1378 static int
1379 add_pmaplist(RPCB *arg)
1380 {
1381         struct pmap pmap;
1382         struct pmaplist *pml;
1383         int h1, h2, h3, h4, p1, p2;
1384
1385         if (strcmp(arg->r_netid, udptrans) == 0) {
1386                 /* It is UDP! */
1387                 pmap.pm_prot = IPPROTO_UDP;
1388         } else if (strcmp(arg->r_netid, tcptrans) == 0) {
1389                 /* It is TCP */
1390                 pmap.pm_prot = IPPROTO_TCP;
1391         } else
1392                 /* Not an IP protocol */
1393                 return (0);
1394
1395         /* interpret the universal address for TCP/IP */
1396         if (sscanf(arg->r_addr, "%d.%d.%d.%d.%d.%d",
1397                 &h1, &h2, &h3, &h4, &p1, &p2) != 6)
1398                 return (0);
1399         pmap.pm_port = ((p1 & 0xff) << 8) + (p2 & 0xff);
1400         pmap.pm_prog = arg->r_prog;
1401         pmap.pm_vers = arg->r_vers;
1402         /*
1403          * add to END of list
1404          */
1405         pml = malloc(sizeof (struct pmaplist));
1406         if (pml == NULL) {
1407                 syslog(LOG_ERR, "rpcbind: no memory!\n");
1408                 return (1);
1409         }
1410         pml->pml_map = pmap;
1411         pml->pml_next = NULL;
1412         if (list_pml == NULL) {
1413                 list_pml = pml;
1414         } else {
1415                 struct pmaplist *fnd;
1416
1417                 /* Attach to the end of the list */
1418                 for (fnd = list_pml; fnd->pml_next; fnd = fnd->pml_next)
1419                         ;
1420                 fnd->pml_next = pml;
1421         }
1422         return (0);
1423 }
1424
1425 /*
1426  * Delete this from the pmap list only if it is UDP or TCP.
1427  */
1428 static int
1429 del_pmaplist(RPCB *arg)
1430 {
1431         struct pmaplist *pml;
1432         struct pmaplist *prevpml, *fnd;
1433         unsigned long prot;
1434
1435         if (strcmp(arg->r_netid, udptrans) == 0) {
1436                 /* It is UDP! */
1437                 prot = IPPROTO_UDP;
1438         } else if (strcmp(arg->r_netid, tcptrans) == 0) {
1439                 /* It is TCP */
1440                 prot = IPPROTO_TCP;
1441         } else if (arg->r_netid[0] == 0) {
1442                 prot = 0;       /* Remove all occurrences */
1443         } else {
1444                 /* Not an IP protocol */
1445                 return (0);
1446         }
1447         for (prevpml = NULL, pml = list_pml; pml; /* cstyle */) {
1448                 if ((pml->pml_map.pm_prog != arg->r_prog) ||
1449                         (pml->pml_map.pm_vers != arg->r_vers) ||
1450                         (prot && (pml->pml_map.pm_prot != prot))) {
1451                         /* both pml & prevpml move forwards */
1452                         prevpml = pml;
1453                         pml = pml->pml_next;
1454                         continue;
1455                 }
1456                 /* found it; pml moves forward, prevpml stays */
1457                 fnd = pml;
1458                 pml = pml->pml_next;
1459                 if (prevpml == NULL)
1460                         list_pml = pml;
1461                 else
1462                         prevpml->pml_next = pml;
1463                 free(fnd);
1464         }
1465         return (0);
1466 }
1467 #endif /* PORTMAP */