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(®, "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, NULL, 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 = 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 */ 1468