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
;