2 * Copyright (c) 2009, Sun Microsystems, Inc.
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met:
7 * - Redistributions of source code must retain the above copyright notice,
8 * this list of conditions and the following disclaimer.
9 * - Redistributions in binary form must reproduce the above copyright notice,
10 * this list of conditions and the following disclaimer in the documentation
11 * and/or other materials provided with the distribution.
12 * - Neither the name of Sun Microsystems, Inc. nor the names of its
13 * contributors may be used to endorse or promote products derived
14 * from this software without specific prior written permission.
16 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
17 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
20 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
21 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
22 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
23 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
24 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
25 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
26 * POSSIBILITY OF SUCH DAMAGE.
28 * @(#)svc_generic.c 1.19 94/04/24 SMI; 1.21 89/02/28 Copyr 1988 Sun Micro
29 * $NetBSD: svc_generic.c,v 1.3 2000/07/06 03:10:35 christos Exp $
30 * $FreeBSD: src/lib/libc/rpc/svc_generic.c,v 1.7 2006/02/27 22:10:59 deischen Exp $
34 * Copyright (c) 1986-1991 by Sun Microsystems Inc.
38 * svc_generic.c, Server side for RPC.
41 #include "namespace.h"
42 #include "reentrant.h"
43 #include <sys/types.h>
44 #include <sys/socket.h>
45 #include <netinet/in.h>
47 #include <rpc/nettype.h>
54 #include "un-namespace.h"
59 extern int __svc_vc_setflag(SVCXPRT *, int);
62 * The highest level interface for server creation.
63 * It tries for all the nettokens in that particular class of token
64 * and returns the number of handles it can create and/or find.
66 * It creates a link list of all the handles it could create.
67 * If svc_create() is called multiple times, it uses the handle
68 * created earlier instead of creating a new handle every time.
71 svc_create(void (*dispatch)(struct svc_req *, SVCXPRT *),
72 rpcprog_t prognum, /* Program number */
73 rpcvers_t versnum, /* Version number */
74 const char *nettype) /* Networktype token */
77 SVCXPRT *xprt; /* Server handle */
78 struct xlist *next; /* Next item */
80 static struct xlist *xprtlist; /* A link list of all the handles */
83 struct netconfig *nconf;
86 /* VARIABLES PROTECTED BY xprtlist_lock: xprtlist */
88 if ((handle = __rpc_setconf(nettype)) == NULL) {
89 warnx("svc_create: unknown protocol");
92 while ((nconf = __rpc_getconf(handle)) != NULL) {
93 mutex_lock(&xprtlist_lock);
94 for (l = xprtlist; l; l = l->next) {
95 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) {
96 /* Found an old one, use it */
97 rpcb_unset(prognum, versnum, nconf);
98 if (svc_reg(l->xprt, prognum, versnum,
99 dispatch, nconf) == FALSE)
101 "svc_create: could not register prog %u vers %u on %s",
102 (unsigned)prognum, (unsigned)versnum,
110 /* It was not found. Now create a new one */
111 xprt = svc_tp_create(dispatch, prognum, versnum, nconf);
113 l = (struct xlist *)malloc(sizeof (*l));
115 warnx("svc_create: no memory");
116 mutex_unlock(&xprtlist_lock);
125 mutex_unlock(&xprtlist_lock);
127 __rpc_endconf(handle);
129 * In case of num == 0; the error messages are generated by the
130 * underlying layers; and hence not needed here.
136 * The high level interface to svc_tli_create().
137 * It tries to create a server for "nconf" and registers the service
138 * with the rpcbind. It calls svc_tli_create();
141 svc_tp_create(void (*dispatch)(struct svc_req *, SVCXPRT *),
142 rpcprog_t prognum, /* Program number */
143 rpcvers_t versnum, /* Version number */
144 const struct netconfig *nconf) /* Netconfig structure for the network */
150 "svc_tp_create: invalid netconfig structure for prog %u vers %u",
151 (unsigned)prognum, (unsigned)versnum);
154 xprt = svc_tli_create(RPC_ANYFD, nconf, NULL, 0, 0);
158 /*LINTED const castaway*/
159 rpcb_unset(prognum, versnum, (struct netconfig *) nconf);
160 if (svc_reg(xprt, prognum, versnum, dispatch, nconf) == FALSE) {
162 "svc_tp_create: Could not register prog %u vers %u on %s",
163 (unsigned)prognum, (unsigned)versnum,
172 * If fd is RPC_ANYFD, then it opens a fd for the given transport
173 * provider (nconf cannot be NULL then). If the t_state is T_UNBND and
174 * bindaddr is NON-NULL, it performs a t_bind using the bindaddr. For
175 * NULL bindadr and Connection oriented transports, the value of qlen
178 * If sendsz or recvsz are zero, their default values are chosen.
182 int fd, /* Connection end point */
183 const struct netconfig *nconf, /* Netconfig struct for nettoken */
184 const struct t_bind *bindaddr, /* Local bind address */
185 u_int sendsz, /* Max sendsize */
186 u_int recvsz) /* Max recvsize */
188 SVCXPRT *xprt = NULL; /* service handle */
189 bool_t madefd = FALSE; /* whether fd opened here */
190 struct __rpc_sockinfo si;
191 struct sockaddr_storage ss;
194 if (fd == RPC_ANYFD) {
196 warnx("svc_tli_create: invalid netconfig");
199 fd = __rpc_nconf2fd(nconf);
202 "svc_tli_create: could not open connection for %s",
206 __rpc_nconf2sockinfo(nconf, &si);
210 * It is an open descriptor. Get the transport info.
212 if (!__rpc_fd2sockinfo(fd, &si)) {
214 "svc_tli_create: could not get transport information");
220 * If the fd is unbound, try to bind it.
222 if (madefd || !__rpc_sockisbound(fd)) {
223 if (bindaddr == NULL) {
224 if (bindresvport(fd, NULL) < 0) {
225 memset(&ss, 0, sizeof ss);
226 ss.ss_family = si.si_af;
227 ss.ss_len = si.si_alen;
228 if (_bind(fd, (struct sockaddr *)(void *)&ss,
229 (socklen_t)si.si_alen) < 0) {
231 "svc_tli_create: could not bind to anonymous port");
235 _listen(fd, SOMAXCONN);
238 (struct sockaddr *)bindaddr->addr.buf,
239 (socklen_t)si.si_alen) < 0) {
241 "svc_tli_create: could not bind to requested address");
244 _listen(fd, (int)bindaddr->qlen);
249 * call transport specific function.
251 switch (si.si_socktype) {
254 if (_getpeername(fd, (struct sockaddr *)(void *)&ss, &slen)
256 /* accepted socket */
257 xprt = svc_fd_create(fd, sendsz, recvsz);
259 xprt = svc_vc_create(fd, sendsz, recvsz);
264 if (strcmp(nconf->nc_protofmly, "inet") == 0 ||
265 strcmp(nconf->nc_protofmly, "inet6") == 0)
266 (void) __svc_vc_setflag(xprt, TRUE);
270 xprt = svc_dg_create(fd, sendsz, recvsz);
273 warnx("svc_tli_create: bad service type");
279 * The error messages here are spitted out by the lower layers:
280 * svc_vc_create(), svc_fd_create() and svc_dg_create().
284 /* Fill in type of service */
285 xprt->xp_type = __rpc_socktype2seman(si.si_socktype);
288 xprt->xp_netid = strdup(nconf->nc_netid);
289 xprt->xp_tp = strdup(nconf->nc_device);
297 if (!madefd) /* so that svc_destroy doesnt close fd */
298 xprt->xp_fd = RPC_ANYFD;