1 /* $NetBSD: rpcb_svc_4.c,v 1.6 2007/05/13 20:03:47 christos Exp $ */ 2 3 /* 4 * Sun RPC is a product of Sun Microsystems, Inc. and is provided for 5 * unrestricted use provided that this legend is included on all tape 6 * media and as a part of the software program in whole or part. Users 7 * may copy or modify Sun RPC without charge, but are not authorized 8 * to license or distribute it to anyone else except as part of a product or 9 * program developed by the user. 10 * 11 * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE 12 * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR 13 * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE. 14 * 15 * Sun RPC is provided with no support and without any obligation on the 16 * part of Sun Microsystems, Inc. to assist in its use, correction, 17 * modification or enhancement. 18 * 19 * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE 20 * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC 21 * OR ANY PART THEREOF. 22 * 23 * In no event will Sun Microsystems, Inc. be liable for any lost revenue 24 * or profits or other special, indirect and consequential damages, even if 25 * Sun has been advised of the possibility of such damages. 26 * 27 * Sun Microsystems, Inc. 28 * 2550 Garcia Avenue 29 * Mountain View, California 94043 30 */ 31 /* 32 * Copyright (c) 1986 - 1991 by Sun Microsystems, Inc. 33 */ 34 35 /* #ident "@(#)rpcb_svc_4.c 1.8 93/07/05 SMI" */ 36 37 /* 38 * rpcb_svc_4.c 39 * The server procedure for the version 4 rpcbind. 40 * 41 */ 42 43 #include <sys/types.h> 44 #include <sys/stat.h> 45 #include <rpc/rpc.h> 46 #include <stdio.h> 47 #include <unistd.h> 48 #include <netconfig.h> 49 #include <syslog.h> 50 #include <string.h> 51 #include <stdlib.h> 52 #include "rpcbind.h" 53 54 static void *rpcbproc_getaddr_4_local(void *, struct svc_req *, SVCXPRT *, 55 rpcvers_t); 56 static void *rpcbproc_getversaddr_4_local(void *, struct svc_req *, SVCXPRT *, 57 rpcvers_t); 58 static void *rpcbproc_getaddrlist_4_local(void *, struct svc_req *, SVCXPRT *, 59 rpcvers_t); 60 static void free_rpcb_entry_list(rpcb_entry_list_ptr *); 61 static void *rpcbproc_dump_4_local(void *, struct svc_req *, SVCXPRT *, 62 rpcvers_t); 63 64 /* 65 * Called by svc_getreqset. There is a separate server handle for 66 * every transport that it waits on. 67 */ 68 void 69 rpcb_service_4(struct svc_req *rqstp, SVCXPRT *transp) 70 { 71 union { 72 rpcb rpcbproc_set_4_arg; 73 rpcb rpcbproc_unset_4_arg; 74 rpcb rpcbproc_getaddr_4_local_arg; 75 char *rpcbproc_uaddr2taddr_4_arg; 76 struct netbuf rpcbproc_taddr2uaddr_4_arg; 77 } argument; 78 char *result; 79 xdrproc_t xdr_argument, xdr_result; 80 void *(*local)(void *, struct svc_req *, SVCXPRT *, rpcvers_t); 81 82 rpcbs_procinfo(RPCBVERS_4_STAT, rqstp->rq_proc); 83 84 switch (rqstp->rq_proc) { 85 case NULLPROC: 86 /* 87 * Null proc call 88 */ 89 #ifdef RPCBIND_DEBUG 90 if (debugging) 91 fprintf(stderr, "RPCBPROC_NULL\n"); 92 #endif 93 check_access(transp, rqstp->rq_proc, NULL, RPCBVERS4); 94 (void) svc_sendreply(transp, (xdrproc_t) xdr_void, 95 (char *)NULL); 96 return; 97 98 case RPCBPROC_SET: 99 /* 100 * Check to see whether the message came from 101 * loopback transports (for security reasons) 102 */ 103 xdr_argument = (xdrproc_t)xdr_rpcb; 104 xdr_result = (xdrproc_t)xdr_bool; 105 local = rpcbproc_set_com; 106 break; 107 108 case RPCBPROC_UNSET: 109 /* 110 * Check to see whether the message came from 111 * loopback transports (for security reasons) 112 */ 113 xdr_argument = (xdrproc_t)xdr_rpcb; 114 xdr_result = (xdrproc_t)xdr_bool; 115 local = rpcbproc_unset_com; 116 break; 117 118 case RPCBPROC_GETADDR: 119 xdr_argument = (xdrproc_t)xdr_rpcb; 120 xdr_result = (xdrproc_t)xdr_wrapstring; 121 local = rpcbproc_getaddr_4_local; 122 break; 123 124 case RPCBPROC_GETVERSADDR: 125 #ifdef RPCBIND_DEBUG 126 if (debugging) 127 fprintf(stderr, "RPCBPROC_GETVERSADDR\n"); 128 #endif 129 xdr_argument = (xdrproc_t)xdr_rpcb; 130 xdr_result = (xdrproc_t)xdr_wrapstring; 131 local = rpcbproc_getversaddr_4_local; 132 break; 133 134 case RPCBPROC_DUMP: 135 #ifdef RPCBIND_DEBUG 136 if (debugging) 137 fprintf(stderr, "RPCBPROC_DUMP\n"); 138 #endif 139 xdr_argument = (xdrproc_t)xdr_void; 140 xdr_result = (xdrproc_t)xdr_rpcblist_ptr; 141 local = rpcbproc_dump_4_local; 142 break; 143 144 case RPCBPROC_INDIRECT: 145 #ifdef RPCBIND_DEBUG 146 if (debugging) 147 fprintf(stderr, "RPCBPROC_INDIRECT\n"); 148 #endif 149 rpcbproc_callit_com(rqstp, transp, rqstp->rq_proc, RPCBVERS4); 150 return; 151 152 /* case RPCBPROC_CALLIT: */ 153 case RPCBPROC_BCAST: 154 #ifdef RPCBIND_DEBUG 155 if (debugging) 156 fprintf(stderr, "RPCBPROC_BCAST\n"); 157 #endif 158 rpcbproc_callit_com(rqstp, transp, rqstp->rq_proc, RPCBVERS4); 159 return; 160 161 case RPCBPROC_GETTIME: 162 #ifdef RPCBIND_DEBUG 163 if (debugging) 164 fprintf(stderr, "RPCBPROC_GETTIME\n"); 165 #endif 166 xdr_argument = (xdrproc_t)xdr_void; 167 xdr_result = (xdrproc_t)xdr_u_long; 168 local = rpcbproc_gettime_com; 169 break; 170 171 case RPCBPROC_UADDR2TADDR: 172 #ifdef RPCBIND_DEBUG 173 if (debugging) 174 fprintf(stderr, "RPCBPROC_UADDR2TADDR\n"); 175 #endif 176 xdr_argument = (xdrproc_t)xdr_wrapstring; 177 xdr_result = (xdrproc_t)xdr_netbuf; 178 local = rpcbproc_uaddr2taddr_com; 179 break; 180 181 case RPCBPROC_TADDR2UADDR: 182 #ifdef RPCBIND_DEBUG 183 if (debugging) 184 fprintf(stderr, "RPCBPROC_TADDR2UADDR\n"); 185 #endif 186 xdr_argument = (xdrproc_t)xdr_netbuf; 187 xdr_result = (xdrproc_t)xdr_wrapstring; 188 local = rpcbproc_taddr2uaddr_com; 189 break; 190 191 case RPCBPROC_GETADDRLIST: 192 #ifdef RPCBIND_DEBUG 193 if (debugging) 194 fprintf(stderr, "RPCBPROC_GETADDRLIST\n"); 195 #endif 196 xdr_argument = (xdrproc_t)xdr_rpcb; 197 xdr_result = (xdrproc_t)xdr_rpcb_entry_list_ptr; 198 local = rpcbproc_getaddrlist_4_local; 199 break; 200 201 case RPCBPROC_GETSTAT: 202 #ifdef RPCBIND_DEBUG 203 if (debugging) 204 fprintf(stderr, "RPCBPROC_GETSTAT\n"); 205 #endif 206 xdr_argument = (xdrproc_t)xdr_void; 207 xdr_result = (xdrproc_t)xdr_rpcb_stat_byvers; 208 local = rpcbproc_getstat; 209 break; 210 211 default: 212 svcerr_noproc(transp); 213 return; 214 } 215 memset((char *)&argument, 0, sizeof (argument)); 216 if (!svc_getargs(transp, (xdrproc_t) xdr_argument, 217 (char *)&argument)) { 218 svcerr_decode(transp); 219 if (debugging) 220 (void) fprintf(stderr, "rpcbind: could not decode\n"); 221 return; 222 } 223 if (!check_access(transp, rqstp->rq_proc, &argument, RPCBVERS4)) { 224 svcerr_weakauth(transp); 225 goto done; 226 } 227 result = (*local)(&argument, rqstp, transp, RPCBVERS4); 228 if (result != NULL && !svc_sendreply(transp, (xdrproc_t) xdr_result, 229 result)) { 230 svcerr_systemerr(transp); 231 if (debugging) { 232 (void) fprintf(stderr, "rpcbind: svc_sendreply\n"); 233 if (doabort) { 234 rpcbind_abort(); 235 } 236 } 237 } 238 done: 239 if (!svc_freeargs(transp, (xdrproc_t) xdr_argument, 240 (char *)&argument)) { 241 if (debugging) { 242 (void) fprintf(stderr, "unable to free arguments\n"); 243 if (doabort) { 244 rpcbind_abort(); 245 } 246 } 247 } 248 return; 249 } 250 251 /* 252 * Lookup the mapping for a program, version and return its 253 * address. Assuming that the caller wants the address of the 254 * server running on the transport on which the request came. 255 * Even if a service with a different version number is available, 256 * it will return that address. The client should check with an 257 * clnt_call to verify whether the service is the one that is desired. 258 * We also try to resolve the universal address in terms of 259 * address of the caller. 260 */ 261 /* ARGSUSED */ 262 static void * 263 rpcbproc_getaddr_4_local(void *arg, struct svc_req *rqstp, SVCXPRT *transp, 264 rpcvers_t rpcbversnum) 265 { 266 RPCB *regp = (RPCB *)arg; 267 #ifdef RPCBIND_DEBUG 268 if (debugging) { 269 char *uaddr; 270 271 uaddr = taddr2uaddr(rpcbind_get_conf(transp->xp_netid), 272 svc_getrpccaller(transp)); 273 fprintf(stderr, "RPCB_GETADDR req for (%lu, %lu, %s) from %s: ", 274 (unsigned long)regp->r_prog, (unsigned long)regp->r_vers, 275 regp->r_netid, uaddr); 276 free(uaddr); 277 } 278 #endif 279 return (rpcbproc_getaddr_com(regp, rqstp, transp, RPCBVERS4, 280 RPCB_ALLVERS)); 281 } 282 283 /* 284 * Lookup the mapping for a program, version and return its 285 * address. Assuming that the caller wants the address of the 286 * server running on the transport on which the request came. 287 * 288 * We also try to resolve the universal address in terms of 289 * address of the caller. 290 */ 291 /* ARGSUSED */ 292 static void * 293 rpcbproc_getversaddr_4_local(void *arg, struct svc_req *rqstp, SVCXPRT *transp, 294 rpcvers_t versnum) 295 { 296 RPCB *regp = (RPCB *)arg; 297 #ifdef RPCBIND_DEBUG 298 if (debugging) { 299 char *uaddr; 300 301 uaddr = taddr2uaddr(rpcbind_get_conf(transp->xp_netid), 302 svc_getrpccaller(transp)); 303 fprintf(stderr, "RPCB_GETVERSADDR rqst for (%lu, %lu, %s)" 304 " from %s : ", 305 (unsigned long)regp->r_prog, (unsigned long)regp->r_vers, 306 regp->r_netid, uaddr); 307 free(uaddr); 308 } 309 #endif 310 return (rpcbproc_getaddr_com(regp, rqstp, transp, RPCBVERS4, 311 RPCB_ONEVERS)); 312 } 313 314 /* 315 * Lookup the mapping for a program, version and return the 316 * addresses for all transports in the current transport family. 317 * We return a merged address. 318 */ 319 /* ARGSUSED */ 320 static void * 321 rpcbproc_getaddrlist_4_local(void *arg, struct svc_req *rqstp, SVCXPRT *transp, 322 rpcvers_t versnum) 323 { 324 RPCB *regp = (RPCB *)arg; 325 static rpcb_entry_list_ptr rlist; 326 register rpcblist_ptr rbl; 327 rpcb_entry_list_ptr rp, tail = NULL; 328 rpcprog_t prog; 329 rpcvers_t vers; 330 rpcb_entry *a; 331 struct netconfig *nconf; 332 struct netconfig *reg_nconf; 333 char *saddr, *maddr = NULL; 334 335 free_rpcb_entry_list(&rlist); 336 prog = regp->r_prog; 337 vers = regp->r_vers; 338 reg_nconf = rpcbind_get_conf(transp->xp_netid); 339 if (reg_nconf == NULL) 340 return (NULL); 341 if (*(regp->r_addr) != '\0') { 342 saddr = regp->r_addr; 343 } else { 344 saddr = NULL; 345 } 346 #ifdef RPCBIND_DEBUG 347 if (debugging) { 348 fprintf(stderr, "r_addr: %s r_netid: %s nc_protofmly: %s\n", 349 regp->r_addr, regp->r_netid, reg_nconf->nc_protofmly); 350 } 351 #endif 352 for (rbl = list_rbl; rbl != NULL; rbl = rbl->rpcb_next) { 353 if ((rbl->rpcb_map.r_prog == prog) && 354 (rbl->rpcb_map.r_vers == vers)) { 355 nconf = rpcbind_get_conf(rbl->rpcb_map.r_netid); 356 if (nconf == NULL) 357 goto fail; 358 if (strcmp(nconf->nc_protofmly, reg_nconf->nc_protofmly) 359 != 0) { 360 continue; /* not same proto family */ 361 } 362 #ifdef RPCBIND_DEBUG 363 if (debugging) 364 fprintf(stderr, "\tmerge with: %s\n", rbl->rpcb_map.r_addr); 365 #endif 366 if ((maddr = mergeaddr(transp, rbl->rpcb_map.r_netid, 367 rbl->rpcb_map.r_addr, saddr)) == NULL) { 368 #ifdef RPCBIND_DEBUG 369 if (debugging) 370 fprintf(stderr, " FAILED\n"); 371 #endif 372 continue; 373 } else if (!maddr[0]) { 374 #ifdef RPCBIND_DEBUG 375 if (debugging) 376 fprintf(stderr, " SUCCEEDED, but port died - maddr: nullstring\n"); 377 #endif 378 /* The server died. Unset this combination */ 379 delete_prog(regp->r_prog); 380 free(maddr); 381 continue; 382 } 383 #ifdef RPCBIND_DEBUG 384 if (debugging) 385 fprintf(stderr, " SUCCEEDED maddr: %s\n", maddr); 386 #endif 387 /* 388 * Add it to rlist. 389 */ 390 rp = (rpcb_entry_list_ptr) 391 malloc((u_int)sizeof (rpcb_entry_list)); 392 if (rp == NULL) { 393 free(maddr); 394 goto fail; 395 } 396 a = &rp->rpcb_entry_map; 397 a->r_maddr = maddr; 398 a->r_nc_netid = nconf->nc_netid; 399 a->r_nc_semantics = nconf->nc_semantics; 400 a->r_nc_protofmly = nconf->nc_protofmly; 401 a->r_nc_proto = nconf->nc_proto; 402 rp->rpcb_entry_next = NULL; 403 if (rlist == NULL) { 404 rlist = rp; 405 tail = rp; 406 } else if (tail) { 407 tail->rpcb_entry_next = rp; 408 tail = rp; 409 } 410 rp = NULL; 411 } 412 } 413 #ifdef RPCBIND_DEBUG 414 if (debugging) { 415 for (rp = rlist; rp; rp = rp->rpcb_entry_next) { 416 fprintf(stderr, "\t%s %s\n", rp->rpcb_entry_map.r_maddr, 417 rp->rpcb_entry_map.r_nc_proto); 418 } 419 } 420 #endif 421 /* 422 * XXX: getaddrlist info is also being stuffed into getaddr. 423 * Perhaps wrong, but better than it not getting counted at all. 424 */ 425 rpcbs_getaddr(RPCBVERS4 - 2, prog, vers, transp->xp_netid, maddr); 426 return (void *)&rlist; 427 428 fail: free_rpcb_entry_list(&rlist); 429 return (NULL); 430 } 431 432 /* 433 * Free only the allocated structure, rest is all a pointer to some 434 * other data somewhere else. 435 */ 436 static void 437 free_rpcb_entry_list(rpcb_entry_list_ptr *rlistp) 438 { 439 register rpcb_entry_list_ptr rbl, tmp; 440 441 for (rbl = *rlistp; rbl != NULL; ) { 442 tmp = rbl; 443 rbl = rbl->rpcb_entry_next; 444 free((char *)tmp->rpcb_entry_map.r_maddr); 445 free((char *)tmp); 446 } 447 *rlistp = NULL; 448 } 449 450 /* ARGSUSED */ 451 static void * 452 rpcbproc_dump_4_local(void *arg, struct svc_req *req, SVCXPRT *xprt, 453 rpcvers_t versnum) 454 { 455 return ((void *)&list_rbl); 456 } 457