1 /* $NetBSD: svc_generic.c,v 1.3 2000/07/06 03:10:35 christos Exp $ */ 2 3 /*- 4 * SPDX-License-Identifier: BSD-3-Clause 5 * 6 * Copyright (c) 2009, Sun Microsystems, Inc. 7 * All rights reserved. 8 * 9 * Redistribution and use in source and binary forms, with or without 10 * modification, are permitted provided that the following conditions are met: 11 * - Redistributions of source code must retain the above copyright notice, 12 * this list of conditions and the following disclaimer. 13 * - Redistributions in binary form must reproduce the above copyright notice, 14 * this list of conditions and the following disclaimer in the documentation 15 * and/or other materials provided with the distribution. 16 * - Neither the name of Sun Microsystems, Inc. nor the names of its 17 * contributors may be used to endorse or promote products derived 18 * from this software without specific prior written permission. 19 * 20 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" 21 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 22 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 23 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE 24 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 25 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 26 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 27 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 28 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) 29 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 30 * POSSIBILITY OF SUCH DAMAGE. 31 */ 32 33 /* 34 * Copyright (c) 1986-1991 by Sun Microsystems Inc. 35 */ 36 37 #if defined(LIBC_SCCS) && !defined(lint) 38 #ident "@(#)svc_generic.c 1.19 94/04/24 SMI" 39 static char sccsid[] = "@(#)svc_generic.c 1.21 89/02/28 Copyr 1988 Sun Micro"; 40 #endif 41 /* 42 * svc_generic.c, Server side for RPC. 43 * 44 */ 45 46 #include "namespace.h" 47 #include "reentrant.h" 48 #include <sys/types.h> 49 #include <sys/socket.h> 50 #include <netinet/in.h> 51 #include <rpc/rpc.h> 52 #include <rpc/nettype.h> 53 #include <stdio.h> 54 #include <errno.h> 55 #include <stdlib.h> 56 #include <string.h> 57 #include <unistd.h> 58 #include <err.h> 59 #include "un-namespace.h" 60 61 #include "rpc_com.h" 62 #include "mt_misc.h" 63 64 extern int __svc_vc_setflag(SVCXPRT *, int); 65 66 /* 67 * The highest level interface for server creation. 68 * It tries for all the nettokens in that particular class of token 69 * and returns the number of handles it can create and/or find. 70 * 71 * It creates a link list of all the handles it could create. 72 * If svc_create() is called multiple times, it uses the handle 73 * created earlier instead of creating a new handle every time. 74 * 75 * prognum - Program number 76 * versnum - Version number 77 * nettype - Networktype token 78 */ 79 int 80 svc_create(void (*dispatch)(struct svc_req *, SVCXPRT *), 81 rpcprog_t prognum, rpcvers_t versnum, const char *nettype) 82 { 83 struct xlist { 84 SVCXPRT *xprt; /* Server handle */ 85 struct xlist *next; /* Next item */ 86 } *l; 87 static struct xlist *xprtlist; /* A link list of all the handles */ 88 int num = 0; 89 SVCXPRT *xprt; 90 struct netconfig *nconf; 91 void *handle; 92 93 /* VARIABLES PROTECTED BY xprtlist_lock: xprtlist */ 94 95 if ((handle = __rpc_setconf(nettype)) == NULL) { 96 warnx("svc_create: unknown protocol"); 97 return (0); 98 } 99 while ((nconf = __rpc_getconf(handle)) != NULL) { 100 mutex_lock(&xprtlist_lock); 101 for (l = xprtlist; l; l = l->next) { 102 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) { 103 /* Found an old one, use it */ 104 (void) rpcb_unset(prognum, versnum, nconf); 105 if (svc_reg(l->xprt, prognum, versnum, 106 dispatch, nconf) == FALSE) 107 warnx( 108 "svc_create: could not register prog %u vers %u on %s", 109 (unsigned)prognum, (unsigned)versnum, 110 nconf->nc_netid); 111 else 112 num++; 113 break; 114 } 115 } 116 if (l == NULL) { 117 /* It was not found. Now create a new one */ 118 xprt = svc_tp_create(dispatch, prognum, versnum, nconf); 119 if (xprt) { 120 l = (struct xlist *)malloc(sizeof (*l)); 121 if (l == NULL) { 122 warnx("svc_create: no memory"); 123 mutex_unlock(&xprtlist_lock); 124 num = 0; 125 goto done; 126 } 127 l->xprt = xprt; 128 l->next = xprtlist; 129 xprtlist = l; 130 num++; 131 } 132 } 133 mutex_unlock(&xprtlist_lock); 134 } 135 done: 136 __rpc_endconf(handle); 137 /* 138 * In case of num == 0; the error messages are generated by the 139 * underlying layers; and hence not needed here. 140 */ 141 return (num); 142 } 143 144 /* 145 * The high level interface to svc_tli_create(). 146 * It tries to create a server for "nconf" and registers the service 147 * with the rpcbind. It calls svc_tli_create(); 148 * 149 * prognum - Program number 150 * versnum - Version number 151 * ncofn - Netconfig structure for the network 152 */ 153 SVCXPRT * 154 svc_tp_create(void (*dispatch)(struct svc_req *, SVCXPRT *), 155 rpcprog_t prognum, rpcvers_t versnum, const struct netconfig *nconf) 156 { 157 SVCXPRT *xprt; 158 159 if (nconf == NULL) { 160 warnx( 161 "svc_tp_create: invalid netconfig structure for prog %u vers %u", 162 (unsigned)prognum, (unsigned)versnum); 163 return (NULL); 164 } 165 xprt = svc_tli_create(RPC_ANYFD, nconf, NULL, 0, 0); 166 if (xprt == NULL) { 167 return (NULL); 168 } 169 /*LINTED const castaway*/ 170 (void) rpcb_unset(prognum, versnum, (struct netconfig *) nconf); 171 if (svc_reg(xprt, prognum, versnum, dispatch, nconf) == FALSE) { 172 warnx( 173 "svc_tp_create: Could not register prog %u vers %u on %s", 174 (unsigned)prognum, (unsigned)versnum, 175 nconf->nc_netid); 176 SVC_DESTROY(xprt); 177 return (NULL); 178 } 179 return (xprt); 180 } 181 182 /* 183 * If fd is RPC_ANYFD, then it opens a fd for the given transport 184 * provider (nconf cannot be NULL then). If the t_state is T_UNBND and 185 * bindaddr is NON-NULL, it performs a t_bind using the bindaddr. For 186 * NULL bindadr and Connection oriented transports, the value of qlen 187 * is set to 8. 188 * 189 * If sendsz or recvsz are zero, their default values are chosen. 190 * 191 * fd - Connection end point 192 * nconf - Netconfig struct for nettoken 193 * bindaddr - Local bind address 194 * sendsz - Max sendsize 195 * recvxz - Max recvsize 196 */ 197 SVCXPRT * 198 svc_tli_create(int fd, const struct netconfig *nconf, 199 const struct t_bind *bindaddr, u_int sendsz, u_int recvsz) 200 { 201 SVCXPRT *xprt = NULL; /* service handle */ 202 bool_t madefd = FALSE; /* whether fd opened here */ 203 struct __rpc_sockinfo si; 204 struct sockaddr_storage ss; 205 socklen_t slen; 206 207 if (fd == RPC_ANYFD) { 208 if (nconf == NULL) { 209 warnx("svc_tli_create: invalid netconfig"); 210 return (NULL); 211 } 212 fd = __rpc_nconf2fd(nconf); 213 if (fd == -1) { 214 warnx( 215 "svc_tli_create: could not open connection for %s", 216 nconf->nc_netid); 217 return (NULL); 218 } 219 __rpc_nconf2sockinfo(nconf, &si); 220 madefd = TRUE; 221 } else { 222 /* 223 * It is an open descriptor. Get the transport info. 224 */ 225 if (!__rpc_fd2sockinfo(fd, &si)) { 226 warnx( 227 "svc_tli_create: could not get transport information"); 228 return (NULL); 229 } 230 } 231 232 /* 233 * If the fd is unbound, try to bind it. 234 */ 235 if (madefd || !__rpc_sockisbound(fd)) { 236 if (bindaddr == NULL) { 237 if (bindresvport(fd, NULL) < 0) { 238 memset(&ss, 0, sizeof ss); 239 ss.ss_family = si.si_af; 240 ss.ss_len = si.si_alen; 241 if (_bind(fd, (struct sockaddr *)(void *)&ss, 242 (socklen_t)si.si_alen) < 0) { 243 warnx( 244 "svc_tli_create: could not bind to anonymous port"); 245 goto freedata; 246 } 247 } 248 _listen(fd, SOMAXCONN); 249 } else { 250 if (_bind(fd, 251 (struct sockaddr *)bindaddr->addr.buf, 252 (socklen_t)si.si_alen) < 0) { 253 warnx( 254 "svc_tli_create: could not bind to requested address"); 255 goto freedata; 256 } 257 _listen(fd, (int)bindaddr->qlen); 258 } 259 260 } 261 /* 262 * call transport specific function. 263 */ 264 switch (si.si_socktype) { 265 case SOCK_STREAM: 266 slen = sizeof ss; 267 if (_getpeername(fd, (struct sockaddr *)(void *)&ss, &slen) 268 == 0) { 269 /* accepted socket */ 270 xprt = svc_fd_create(fd, sendsz, recvsz); 271 } else 272 xprt = svc_vc_create(fd, sendsz, recvsz); 273 if (!nconf || !xprt) 274 break; 275 #if 0 276 /* XXX fvdl */ 277 if (strcmp(nconf->nc_protofmly, "inet") == 0 || 278 strcmp(nconf->nc_protofmly, "inet6") == 0) 279 (void) __svc_vc_setflag(xprt, TRUE); 280 #endif 281 break; 282 case SOCK_DGRAM: 283 xprt = svc_dg_create(fd, sendsz, recvsz); 284 break; 285 default: 286 warnx("svc_tli_create: bad service type"); 287 goto freedata; 288 } 289 290 if (xprt == NULL) 291 /* 292 * The error messages here are spitted out by the lower layers: 293 * svc_vc_create(), svc_fd_create() and svc_dg_create(). 294 */ 295 goto freedata; 296 297 /* Fill in type of service */ 298 xprt->xp_type = __rpc_socktype2seman(si.si_socktype); 299 300 if (nconf) { 301 xprt->xp_netid = strdup(nconf->nc_netid); 302 xprt->xp_tp = strdup(nconf->nc_device); 303 } 304 return (xprt); 305 306 freedata: 307 if (madefd) 308 (void)_close(fd); 309 if (xprt) { 310 if (!madefd) /* so that svc_destroy doesnt close fd */ 311 xprt->xp_fd = RPC_ANYFD; 312 SVC_DESTROY(xprt); 313 } 314 return (NULL); 315 } 316