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