1 /* $NetBSD: rpcb_svc_com.c,v 1.6 2000/08/03 00:07:22 fvdl Exp $ */
5 * Sun RPC is a product of Sun Microsystems, Inc. and is provided for
6 * unrestricted use provided that this legend is included on all tape
7 * media and as a part of the software program in whole or part. Users
8 * may copy or modify Sun RPC without charge, but are not authorized
9 * to license or distribute it to anyone else except as part of a product or
10 * program developed by the user.
12 * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE
13 * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR
14 * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE.
16 * Sun RPC is provided with no support and without any obligation on the
17 * part of Sun Microsystems, Inc. to assist in its use, correction,
18 * modification or enhancement.
20 * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE
21 * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC
22 * OR ANY PART THEREOF.
24 * In no event will Sun Microsystems, Inc. be liable for any lost revenue
25 * or profits or other special, indirect and consequential damages, even if
26 * Sun has been advised of the possibility of such damages.
28 * Sun Microsystems, Inc.
30 * Mountain View, California 94043
33 * Copyright (c) 1986 - 1991 by Sun Microsystems, Inc.
36 /* #ident "@(#)rpcb_svc_com.c 1.18 94/05/02 SMI" */
40 * The commom server procedure for the rpcbind.
43 #include <sys/types.h>
45 #include <sys/param.h>
47 #include <sys/socket.h>
49 #include <rpc/rpcb_prot.h>
50 #include <rpc/svc_dg.h>
51 #include <netconfig.h>
57 #include <netinet/in.h>
58 #include <rpc/pmap_prot.h>
65 #define RPC_BUF_MAX 65536 /* can be raised if required */
67 static char *nullstring = "";
68 static int rpcb_rmtcalls;
70 struct rmtcallfd_list {
74 struct rmtcallfd_list *next;
78 #define MAXTIME_OFF 300 /* 5 minutes */
82 #define FINFO_ACTIVE 0x1
84 struct netbuf *caller_addr;
85 u_int32_t forward_xid;
92 static struct finfo FINFO[NFORWARD];
95 static bool_t xdr_encap_parms __P((XDR *, struct encap_parms *));
96 static bool_t xdr_rmtcall_args __P((XDR *, struct r_rmtcall_args *));
97 static bool_t xdr_rmtcall_result __P((XDR *, struct r_rmtcall_args *));
98 static bool_t xdr_opaque_parms __P((XDR *, struct r_rmtcall_args *));
99 static int find_rmtcallfd_by_netid __P((char *));
100 static SVCXPRT *find_rmtcallxprt_by_fd __P((int));
101 static int forward_register __P((u_int32_t, struct netbuf *, int, char *,
102 rpcproc_t, rpcvers_t, u_int32_t *));
103 static struct finfo *forward_find __P((u_int32_t));
104 static int free_slot_by_xid __P((u_int32_t));
105 static int free_slot_by_index __P((int));
106 static int netbufcmp __P((struct netbuf *, struct netbuf *));
107 static struct netbuf *netbufdup __P((struct netbuf *));
108 static void netbuffree __P((struct netbuf *));
109 static int check_rmtcalls __P((struct pollfd *, int));
110 static void xprt_set_caller __P((SVCXPRT *, struct finfo *));
111 static void send_svcsyserr __P((SVCXPRT *, struct finfo *));
112 static void handle_reply __P((int, SVCXPRT *));
113 static void find_versions __P((rpcprog_t, char *, rpcvers_t *, rpcvers_t *));
114 static rpcblist_ptr find_service __P((rpcprog_t, rpcvers_t, char *));
115 static char *getowner __P((SVCXPRT *, char *, size_t));
116 static int add_pmaplist __P((RPCB *));
117 static int del_pmaplist __P((RPCB *));
120 * Set a mapping of program, version, netid
124 rpcbproc_set_com(void *arg, struct svc_req *rqstp, SVCXPRT *transp,
125 rpcvers_t rpcbversnum)
127 RPCB *regp = (RPCB *)arg;
133 fprintf(stderr, "RPCB_SET request for (%lu, %lu, %s, %s) : ",
134 (unsigned long)regp->r_prog, (unsigned long)regp->r_vers,
135 regp->r_netid, regp->r_addr);
137 ans = map_set(regp, getowner(transp, owner, sizeof owner));
140 fprintf(stderr, "%s\n", ans == TRUE ? "succeeded" : "failed");
142 /* XXX: should have used some defined constant here */
143 rpcbs_set(rpcbversnum - 2, ans);
148 map_set(RPCB *regp, char *owner)
151 rpcblist_ptr rbl, fnd;
155 * check to see if already used
156 * find_service returns a hit even if
157 * the versions don't match, so check for it
159 fnd = find_service(reg.r_prog, reg.r_vers, reg.r_netid);
160 if (fnd && (fnd->rpcb_map.r_vers == reg.r_vers)) {
161 if (!strcmp(fnd->rpcb_map.r_addr, reg.r_addr))
163 * if these match then it is already
164 * registered so just say "OK".
171 * add to the end of the list
173 rbl = (rpcblist_ptr) malloc((u_int)sizeof (RPCBLIST));
174 if (rbl == (rpcblist_ptr)NULL) {
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) {
193 rbl->rpcb_next = (rpcblist_ptr)NULL;
194 if (list_rbl == NULL) {
197 for (fnd = list_rbl; fnd->rpcb_next;
198 fnd = fnd->rpcb_next)
200 fnd->rpcb_next = rbl;
203 (void) add_pmaplist(regp);
209 * Unset a mapping of program, version, netid
213 rpcbproc_unset_com(void *arg, struct svc_req *rqstp, SVCXPRT *transp,
214 rpcvers_t rpcbversnum)
216 RPCB *regp = (RPCB *)arg;
222 fprintf(stderr, "RPCB_UNSET request for (%lu, %lu, %s) : ",
223 (unsigned long)regp->r_prog, (unsigned long)regp->r_vers,
226 ans = map_unset(regp, getowner(transp, owner, sizeof owner));
229 fprintf(stderr, "%s\n", ans == TRUE ? "succeeded" : "failed");
231 /* XXX: should have used some defined constant here */
232 rpcbs_unset(rpcbversnum - 2, ans);
237 map_unset(RPCB *regp, char *owner)
240 rpcblist_ptr rbl, prev, tmp;
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 */
252 rbl = rbl->rpcb_next;
256 * Check whether appropriate uid. Unset only
257 * if superuser or the owner itself.
259 if (strcmp(owner, "superuser") &&
260 strcmp(rbl->rpcb_map.r_owner, owner))
262 /* found it; rbl moves forward, prev stays */
265 rbl = rbl->rpcb_next;
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);
277 (void) del_pmaplist(regp);
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.
288 delete_prog(int prog)
291 register rpcblist_ptr rbl;
293 for (rbl = list_rbl; rbl != NULL; rbl = rbl->rpcb_next) {
294 if ((rbl->rpcb_map.r_prog != prog))
296 if (is_bound(rbl->rpcb_map.r_netid, rbl->rpcb_map.r_addr))
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 (void) map_unset(®, "superuser");
307 rpcbproc_getaddr_com(RPCB *regp, struct svc_req *rqstp, SVCXPRT *transp,
308 rpcvers_t rpcbversnum, rpcvers_t verstype)
314 if (uaddr != NULL && uaddr != nullstring) {
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 */
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]) {
330 * The server died. Unset all versions of this prog.
332 delete_prog(regp->r_prog);
340 fprintf(stderr, "getaddr: %s\n", uaddr);
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;
350 rpcbproc_gettime_com(void *arg, struct svc_req *rqstp, SVCXPRT *transp,
351 rpcvers_t rpcbversnum)
353 static time_t curtime;
355 (void) time(&curtime);
356 return (void *)&curtime;
360 * Convert uaddr to taddr. Should be used only by
361 * local servers/clients. (kernel level stuff only)
365 rpcbproc_uaddr2taddr_com(void *arg, struct svc_req *rqstp, SVCXPRT *transp,
366 rpcvers_t rpcbversnum)
368 char **uaddrp = (char **)arg;
369 struct netconfig *nconf;
370 static struct netbuf nbuf;
371 static struct netbuf *taddr;
378 if (((nconf = rpcbind_get_conf(transp->xp_netid)) == NULL) ||
379 ((taddr = uaddr2taddr(nconf, *uaddrp)) == NULL)) {
380 (void) memset((char *)&nbuf, 0, sizeof (struct netbuf));
381 return (void *)&nbuf;
383 return (void *)taddr;
387 * Convert taddr to uaddr. Should be used only by
388 * local servers/clients. (kernel level stuff only)
392 rpcbproc_taddr2uaddr_com(void *arg, struct svc_req *rqstp, SVCXPRT *transp,
393 rpcvers_t rpcbversnum)
395 struct netbuf *taddr = (struct netbuf *)arg;
397 struct netconfig *nconf;
402 if ((fd = open("/dev/null", O_RDONLY)) == -1) {
403 uaddr = (char *)strerror(errno);
406 #endif /* CHEW_FDS */
407 if (uaddr != NULL && uaddr != nullstring) {
411 if (((nconf = rpcbind_get_conf(transp->xp_netid)) == NULL) ||
412 ((uaddr = taddr2uaddr(nconf, taddr)) == NULL)) {
415 return (void *)&uaddr;
420 xdr_encap_parms(XDR *xdrs, struct encap_parms *epp)
422 return (xdr_bytes(xdrs, &(epp->args), (u_int *) &(epp->arglen), ~0));
426 * XDR remote call arguments. It ignores the address part.
427 * written for XDR_DECODE direction only
430 xdr_rmtcall_args(XDR *xdrs, struct r_rmtcall_args *cap)
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)));
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.
447 xdr_rmtcall_result(XDR *xdrs, struct r_rmtcall_args *cap)
452 if (cap->rmt_localvers == PMAPVERS) {
453 int h1, h2, h3, h4, p1, p2;
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)
460 port = ((p1 & 0xff) << 8) + (p2 & 0xff);
461 result = xdr_u_long(xdrs, &port);
464 if ((cap->rmt_localvers == RPCBVERS) ||
465 (cap->rmt_localvers == RPCBVERS4)) {
466 result = xdr_wrapstring(xdrs, &(cap->rmt_uaddr));
471 return (xdr_encap_parms(xdrs, &(cap->rmt_args)));
476 * only worries about the struct encap_parms part of struct r_rmtcall_args.
477 * The arglen must already be set!!
480 xdr_opaque_parms(XDR *xdrs, struct r_rmtcall_args *cap)
482 return (xdr_opaque(xdrs, cap->rmt_args.args, cap->rmt_args.arglen));
485 static struct rmtcallfd_list *rmthead;
486 static struct rmtcallfd_list *rmttail;
489 create_rmtcall_fd(struct netconfig *nconf)
492 struct rmtcallfd_list *rmt;
495 if ((fd = __rpc_nconf2fd(nconf)) == -1) {
498 "create_rmtcall_fd: couldn't open \"%s\" (errno %d)\n",
499 nconf->nc_device, errno);
502 xprt = svc_tli_create(fd, 0, (struct t_bind *) 0, 0, 0);
506 "create_rmtcall_fd: svc_tli_create failed\n");
509 rmt = (struct rmtcallfd_list *)malloc((u_int)
510 sizeof (struct rmtcallfd_list));
512 syslog(LOG_ERR, "create_rmtcall_fd: no memory!");
516 rmt->netid = strdup(nconf->nc_netid);
517 xprt->xp_netid = rmt->netid;
520 if (rmthead == NULL) {
527 /* XXX not threadsafe */
530 FD_SET(fd, &svc_fdset);
535 find_rmtcallfd_by_netid(char *netid)
537 struct rmtcallfd_list *rmt;
539 for (rmt = rmthead; rmt != NULL; rmt = rmt->next) {
540 if (strcmp(netid, rmt->netid) == 0) {
548 find_rmtcallxprt_by_fd(int fd)
550 struct rmtcallfd_list *rmt;
552 for (rmt = rmthead; rmt != NULL; rmt = rmt->next) {
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
568 * receive the request
570 * open a new TLI endpoint on the same transport on which we received
571 * the original request
573 * remember the original request's XID (which requires knowing the format
574 * of the svc_dg_data structure)
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.
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
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
592 * bundle the reply, along with the service's universal address
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.
600 rpcbproc_callit_com(struct svc_req *rqstp, SVCXPRT *transp,
601 rpcproc_t reply_type, rpcvers_t versnum)
603 register 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;
617 char *uaddr, *m_uaddr = NULL, *local_uaddr = NULL;
619 struct __rpc_sockinfo si;
620 struct sockaddr *localsa;
623 if (!__rpc_fd2sockinfo(transp->xp_fd, &si)) {
624 if (reply_type == RPCBPROC_INDIRECT)
625 svcerr_systemerr(transp);
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);
637 * Should be multiple of 4 for XDR.
639 sendsz = ((sendsz + 3) / 4) * 4;
640 if (sendsz > RPC_BUF_MAX) {
642 buf_alloc = alloca(sendsz); /* not in IDR2? */
644 buf_alloc = malloc(sendsz);
646 if (buf_alloc == NULL) {
649 "rpcbproc_callit_com: No Memory!\n");
650 if (reply_type == RPCBPROC_INDIRECT)
651 svcerr_systemerr(transp);
654 a.rmt_args.args = buf_alloc;
656 a.rmt_args.args = buf;
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);
665 "rpcbproc_callit_com: svc_getargs failed\n");
669 if (!check_callit(transp, &a, versnum)) {
670 svcerr_weakauth(transp);
674 caller = svc_getrpccaller(transp);
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");
691 rbl = find_service(a.rmt_prog, a.rmt_vers, transp->xp_netid);
693 rpcbs_rmtcall(versnum - 2, reply_type, a.rmt_prog, a.rmt_vers,
694 a.rmt_proc, transp->xp_netid, rbl);
696 if (rbl == (rpcblist_ptr)NULL) {
699 fprintf(stderr, "not found\n");
701 if (reply_type == RPCBPROC_INDIRECT)
702 svcerr_noprog(transp);
705 if (rbl->rpcb_map.r_vers != a.rmt_vers) {
706 if (reply_type == RPCBPROC_INDIRECT) {
707 rpcvers_t vers_low, vers_high;
709 find_versions(a.rmt_prog, transp->xp_netid,
710 &vers_low, &vers_high);
711 svcerr_progvers(transp, vers_low, vers_high);
718 fprintf(stderr, "found at uaddr %s\n", rbl->rpcb_map.r_addr);
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).
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);
737 nconf = rpcbind_get_conf(transp->xp_netid);
738 if (nconf == (struct netconfig *)NULL) {
739 if (reply_type == RPCBPROC_INDIRECT)
740 svcerr_systemerr(transp);
743 "rpcbproc_callit_com: rpcbind_get_conf failed\n");
746 localsa = local_sa(((struct sockaddr *)caller->buf)->sa_family);
747 if (localsa == NULL) {
750 "rpcbproc_callit_com: no local address\n");
753 tbuf.len = tbuf.maxlen = localsa->sa_len;
756 addrmerge(&tbuf, rbl->rpcb_map.r_addr, NULL, nconf->nc_netid);
757 m_uaddr = addrmerge(caller, rbl->rpcb_map.r_addr, NULL,
761 fprintf(stderr, "merged uaddr %s\n", m_uaddr);
763 if ((fd = find_rmtcallfd_by_netid(nconf->nc_netid)) == -1) {
764 if (reply_type == RPCBPROC_INDIRECT)
765 svcerr_systemerr(transp);
768 xidp = __rpcb_get_dg_xidp(transp);
769 switch (forward_register(*xidp, caller, fd, m_uaddr, reply_type,
770 versnum, &call_msg.rm_xid)) {
772 /* Success; forward_register() will free m_uaddr for us. */
777 * A duplicate request for the slow server. Let's not
778 * beat on it any more.
782 "rpcbproc_callit_com: duplicate request\n");
785 /* forward_register failed. Perhaps no memory. */
788 "rpcbproc_callit_com: forward_register failed\n");
795 "rpcbproc_callit_com: original XID %x, new XID %x\n",
796 *xidp, call_msg.rm_xid);
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) {
804 outbuf_alloc = alloca(sendsz); /* not in IDR2? */
806 outbuf_alloc = malloc(sendsz);
808 if (outbuf_alloc == NULL) {
809 if (reply_type == RPCBPROC_INDIRECT)
810 svcerr_systemerr(transp);
813 "rpcbproc_callit_com: No memory!\n");
816 xdrmem_create(&outxdr, outbuf_alloc, sendsz, XDR_ENCODE);
818 xdrmem_create(&outxdr, outbuf, sendsz, XDR_ENCODE);
820 if (!xdr_callhdr(&outxdr, &call_msg)) {
821 if (reply_type == RPCBPROC_INDIRECT)
822 svcerr_systemerr(transp);
825 "rpcbproc_callit_com: xdr_callhdr failed\n");
828 if (!xdr_u_int32_t(&outxdr, &(a.rmt_proc))) {
829 if (reply_type == RPCBPROC_INDIRECT)
830 svcerr_systemerr(transp);
833 "rpcbproc_callit_com: xdr_u_long failed\n");
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;
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();
849 /* we do not support any other authentication scheme */
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.. */
858 if (reply_type == RPCBPROC_INDIRECT)
859 svcerr_systemerr(transp);
862 "rpcbproc_callit_com: authwhatever_create returned NULL\n");
865 if (!AUTH_MARSHALL(auth, &outxdr)) {
866 if (reply_type == RPCBPROC_INDIRECT)
867 svcerr_systemerr(transp);
871 "rpcbproc_callit_com: AUTH_MARSHALL failed\n");
875 if (!xdr_opaque_parms(&outxdr, &a)) {
876 if (reply_type == RPCBPROC_INDIRECT)
877 svcerr_systemerr(transp);
880 "rpcbproc_callit_com: xdr_opaque_parms failed\n");
883 outlen = (int) XDR_GETPOS(&outxdr);
885 outbufp = outbuf_alloc;
889 na = uaddr2taddr(nconf, local_uaddr);
891 if (reply_type == RPCBPROC_INDIRECT)
892 svcerr_systemerr(transp);
896 if (sendto(fd, outbufp, outlen, 0, (struct sockaddr *)na->buf, na->len)
900 "rpcbproc_callit_com: sendto failed: errno %d\n", errno);
901 if (reply_type == RPCBPROC_INDIRECT)
902 svcerr_systemerr(transp);
908 if (call_msg.rm_xid != 0)
909 (void) free_slot_by_xid(call_msg.rm_xid);
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.
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)
937 time_t min_time, time_now;
938 static u_int32_t lastxid;
941 min_time = FINFO[0].time;
942 time_now = time((time_t *)0);
945 lastxid = time_now * NFORWARD;
948 * Check if it is an duplicate entry. Then,
949 * try to find an empty slot. If not available, then
950 * use the slot with the earliest time.
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,
959 FINFO[i].time = time((time_t *)0);
960 return (0); /* Duplicate entry */
962 /* Should we wait any longer */
963 if ((time_now - FINFO[i].time) > MAXTIME_OFF)
964 (void) free_slot_by_index(i);
968 if ((FINFO[i].flag & FINFO_ACTIVE) == 0) {
970 } else if (FINFO[i].time < min_time) {
972 min_time = FINFO[i].time;
977 /* use this empty slot */
980 (void) free_slot_by_index(j);
982 if ((FINFO[j].caller_addr = netbufdup(caller_addr)) == NULL) {
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;
993 * Though uaddr is not allocated here, it will still be freed
994 * from free_slot_*().
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)
1001 FINFO[j].forward_xid = lastxid + j; /* encode slot */
1002 *callxidp = FINFO[j].forward_xid; /* forward on this xid */
1006 static struct finfo *
1007 forward_find(u_int32_t reply_xid)
1011 i = reply_xid % (u_int32_t)NFORWARD;
1012 if ((FINFO[i].flag & FINFO_ACTIVE) &&
1013 (FINFO[i].forward_xid == reply_xid)) {
1020 free_slot_by_xid(u_int32_t xid)
1024 entry = xid % (u_int32_t)NFORWARD;
1025 return (free_slot_by_index(entry));
1029 free_slot_by_index(int 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)
1040 fi->flag &= ~FINFO_ACTIVE;
1048 netbufcmp(struct netbuf *n1, struct netbuf *n2)
1050 return ((n1->len != n2->len) || memcmp(n1->buf, n2->buf, n1->len));
1053 static struct netbuf *
1054 netbufdup(struct netbuf *ap)
1058 if ((np = malloc(sizeof(struct netbuf))) == NULL)
1060 if ((np->buf = malloc(ap->len)) == NULL) {
1064 np->maxlen = np->len = ap->len;
1065 memcpy(np->buf, ap->buf, ap->len);
1070 netbuffree(struct netbuf *ap)
1077 #define MASKVAL (POLLIN | POLLPRI | POLLRDNORM | POLLRDBAND)
1083 struct pollfd pollfds[FD_SETSIZE];
1084 int poll_ret, check_ret;
1086 #ifdef SVC_RUN_DEBUG
1089 register struct pollfd *p;
1093 for (n = 0; n <= svc_maxfd; n++) {
1094 if (FD_ISSET(n, &svc_fdset)) {
1096 p->events = MASKVAL;
1102 #ifdef SVC_RUN_DEBUG
1104 fprintf(stderr, "polling for read on fd < ");
1105 for (i = 0, p = pollfds; i < nfds; i++, p++)
1107 fprintf(stderr, "%d ", p->fd);
1108 fprintf(stderr, ">\n");
1111 switch (poll_ret = poll(pollfds, nfds, INFTIM)) {
1114 * We ignore all errors, continuing with the assumption
1115 * that it was set by the signal handlers (or any
1116 * other outside event) and not caused by poll().
1121 #ifdef SVC_RUN_DEBUG
1123 fprintf(stderr, "poll returned read fds < ");
1124 for (i = 0, p = pollfds; i < nfds; i++, p++)
1126 fprintf(stderr, "%d ", p->fd);
1127 fprintf(stderr, ">\n");
1131 * If we found as many replies on callback fds
1132 * as the number of descriptors selectable which
1133 * poll() returned, there can be no more so we
1134 * don't call svc_getreq_poll. Otherwise, there
1135 * must be another so we must call svc_getreq_poll.
1137 if ((check_ret = check_rmtcalls(pollfds, nfds)) ==
1140 svc_getreq_poll(pollfds, poll_ret-check_ret);
1142 #ifdef SVC_RUN_DEBUG
1144 fprintf(stderr, "svc_maxfd now %u\n", svc_maxfd);
1151 check_rmtcalls(struct pollfd *pfds, int nfds)
1153 int j, ncallbacks_found = 0, rmtcalls_pending;
1156 if (rpcb_rmtcalls == 0)
1159 rmtcalls_pending = rpcb_rmtcalls;
1160 for (j = 0; j < nfds; j++) {
1161 if ((xprt = find_rmtcallxprt_by_fd(pfds[j].fd)) != NULL) {
1162 if (pfds[j].revents) {
1164 #ifdef DEBUG_RMTCALL
1167 "my_svc_run: polled on forwarding fd %d, netid %s - calling handle_reply\n",
1168 pfds[j].fd, xprt->xp_netid);
1170 handle_reply(pfds[j].fd, xprt);
1171 pfds[j].revents = 0;
1172 if (ncallbacks_found >= rmtcalls_pending) {
1178 return (ncallbacks_found);
1182 xprt_set_caller(SVCXPRT *xprt, struct finfo *fi)
1186 *(svc_getrpccaller(xprt)) = *(fi->caller_addr);
1187 xidp = __rpcb_get_dg_xidp(xprt);
1188 *xidp = fi->caller_xid;
1192 * Call svcerr_systemerr() only if RPCBVERS4
1195 send_svcsyserr(SVCXPRT *xprt, struct finfo *fi)
1197 if (fi->reply_type == RPCBPROC_INDIRECT) {
1198 xprt_set_caller(xprt, fi);
1199 svcerr_systemerr(xprt);
1205 handle_reply(int fd, SVCXPRT *xprt)
1208 struct rpc_msg reply_msg;
1209 struct rpc_err reply_error;
1212 int inlen, pos, len;
1213 struct r_rmtcall_args a;
1214 struct sockaddr_storage ss;
1216 #ifdef SVC_RUN_DEBUG
1220 buffer = malloc(RPC_BUF_MAX);
1225 inlen = recvfrom(fd, buffer, RPC_BUF_MAX, 0,
1226 (struct sockaddr *)&ss, &fromlen);
1227 } while (inlen < 0 && errno == EINTR);
1231 "handle_reply: recvfrom returned %d, errno %d\n", inlen, errno);
1235 reply_msg.acpted_rply.ar_verf = _null_auth;
1236 reply_msg.acpted_rply.ar_results.where = 0;
1237 reply_msg.acpted_rply.ar_results.proc = (xdrproc_t) xdr_void;
1239 xdrmem_create(&reply_xdrs, buffer, (u_int)inlen, XDR_DECODE);
1240 if (!xdr_replymsg(&reply_xdrs, &reply_msg)) {
1242 (void) fprintf(stderr,
1243 "handle_reply: xdr_replymsg failed\n");
1246 fi = forward_find(reply_msg.rm_xid);
1247 #ifdef SVC_RUN_DEBUG
1249 fprintf(stderr, "handle_reply: reply xid: %d fi addr: %p\n",
1250 reply_msg.rm_xid, fi);
1256 _seterr_reply(&reply_msg, &reply_error);
1257 if (reply_error.re_status != RPC_SUCCESS) {
1259 (void) fprintf(stderr, "handle_reply: %s\n",
1260 clnt_sperrno(reply_error.re_status));
1261 send_svcsyserr(xprt, fi);
1264 pos = XDR_GETPOS(&reply_xdrs);
1266 a.rmt_args.args = &buffer[pos];
1267 a.rmt_args.arglen = len;
1268 a.rmt_uaddr = fi->uaddr;
1269 a.rmt_localvers = fi->versnum;
1271 xprt_set_caller(xprt, fi);
1272 #ifdef SVC_RUN_DEBUG
1273 uaddr = taddr2uaddr(rpcbind_get_conf("udp"),
1274 svc_getrpccaller(xprt));
1276 fprintf(stderr, "handle_reply: forwarding address %s to %s\n",
1277 a.rmt_uaddr, uaddr ? uaddr : "unknown");
1282 svc_sendreply(xprt, (xdrproc_t) xdr_rmtcall_result, (char *) &a);
1287 if (reply_msg.rm_xid == 0) {
1288 #ifdef SVC_RUN_DEBUG
1290 fprintf(stderr, "handle_reply: NULL xid on exit!\n");
1294 (void) free_slot_by_xid(reply_msg.rm_xid);
1299 find_versions(rpcprog_t prog, char *netid, rpcvers_t *lowvp, rpcvers_t *highvp)
1301 register rpcblist_ptr rbl;
1305 for (rbl = list_rbl; rbl != NULL; rbl = rbl->rpcb_next) {
1306 if ((rbl->rpcb_map.r_prog != prog) ||
1307 ((rbl->rpcb_map.r_netid != NULL) &&
1308 (strcasecmp(rbl->rpcb_map.r_netid, netid) != 0)))
1311 highv = rbl->rpcb_map.r_vers;
1313 } else if (rbl->rpcb_map.r_vers < lowv) {
1314 lowv = rbl->rpcb_map.r_vers;
1315 } else if (rbl->rpcb_map.r_vers > highv) {
1316 highv = rbl->rpcb_map.r_vers;
1325 * returns the item with the given program, version number and netid.
1326 * If that version number is not found, it returns the item with that
1327 * program number, so that address is now returned to the caller. The
1328 * caller when makes a call to this program, version number, the call
1329 * will fail and it will return with PROGVERS_MISMATCH. The user can
1330 * then determine the highest and the lowest version number for this
1331 * program using clnt_geterr() and use those program version numbers.
1333 * Returns the RPCBLIST for the given prog, vers and netid
1336 find_service(rpcprog_t prog, rpcvers_t vers, char *netid)
1338 register rpcblist_ptr hit = NULL;
1339 register rpcblist_ptr rbl;
1341 for (rbl = list_rbl; rbl != NULL; rbl = rbl->rpcb_next) {
1342 if ((rbl->rpcb_map.r_prog != prog) ||
1343 ((rbl->rpcb_map.r_netid != NULL) &&
1344 (strcasecmp(rbl->rpcb_map.r_netid, netid) != 0)))
1347 if (rbl->rpcb_map.r_vers == vers)
1354 * Copies the name associated with the uid of the caller and returns
1355 * a pointer to it. Similar to getwd().
1358 getowner(SVCXPRT *transp, char *owner, size_t ownersize)
1362 if (__rpc_get_local_uid(transp, &uid) < 0)
1363 strlcpy(owner, "unknown", ownersize);
1365 strlcpy(owner, "superuser", ownersize);
1367 snprintf(owner, ownersize, "%d", uid);
1374 * Add this to the pmap list only if it is UDP or TCP.
1377 add_pmaplist(RPCB *arg)
1380 struct pmaplist *pml;
1381 int h1, h2, h3, h4, p1, p2;
1383 if (strcmp(arg->r_netid, udptrans) == 0) {
1385 pmap.pm_prot = IPPROTO_UDP;
1386 } else if (strcmp(arg->r_netid, tcptrans) == 0) {
1388 pmap.pm_prot = IPPROTO_TCP;
1390 /* Not a IP protocol */
1393 /* interpret the universal address for TCP/IP */
1394 if (sscanf(arg->r_addr, "%d.%d.%d.%d.%d.%d",
1395 &h1, &h2, &h3, &h4, &p1, &p2) != 6)
1397 pmap.pm_port = ((p1 & 0xff) << 8) + (p2 & 0xff);
1398 pmap.pm_prog = arg->r_prog;
1399 pmap.pm_vers = arg->r_vers;
1401 * add to END of list
1403 pml = (struct pmaplist *) malloc((u_int)sizeof (struct pmaplist));
1405 (void) syslog(LOG_ERR, "rpcbind: no memory!\n");
1408 pml->pml_map = pmap;
1409 pml->pml_next = NULL;
1410 if (list_pml == NULL) {
1413 struct pmaplist *fnd;
1415 /* Attach to the end of the list */
1416 for (fnd = list_pml; fnd->pml_next; fnd = fnd->pml_next)
1418 fnd->pml_next = pml;
1424 * Delete this from the pmap list only if it is UDP or TCP.
1427 del_pmaplist(RPCB *arg)
1429 struct pmaplist *pml;
1430 struct pmaplist *prevpml, *fnd;
1433 if (strcmp(arg->r_netid, udptrans) == 0) {
1436 } else if (strcmp(arg->r_netid, tcptrans) == 0) {
1439 } else if (arg->r_netid[0] == NULL) {
1440 prot = 0; /* Remove all occurrences */
1442 /* Not a IP protocol */
1445 for (prevpml = NULL, pml = list_pml; pml; /* cstyle */) {
1446 if ((pml->pml_map.pm_prog != arg->r_prog) ||
1447 (pml->pml_map.pm_vers != arg->r_vers) ||
1448 (prot && (pml->pml_map.pm_prot != prot))) {
1449 /* both pml & prevpml move forwards */
1451 pml = pml->pml_next;
1454 /* found it; pml moves forward, prevpml stays */
1456 pml = pml->pml_next;
1457 if (prevpml == NULL)
1460 prevpml->pml_next = pml;
1465 #endif /* PORTMAP */