rpc_generic.c revision 1.25 1 1.25 christos /* $NetBSD: rpc_generic.c,v 1.25 2012/03/13 21:13:44 christos Exp $ */
2 1.1 fvdl
3 1.1 fvdl /*
4 1.1 fvdl * Sun RPC is a product of Sun Microsystems, Inc. and is provided for
5 1.1 fvdl * unrestricted use provided that this legend is included on all tape
6 1.1 fvdl * media and as a part of the software program in whole or part. Users
7 1.1 fvdl * may copy or modify Sun RPC without charge, but are not authorized
8 1.1 fvdl * to license or distribute it to anyone else except as part of a product or
9 1.1 fvdl * program developed by the user.
10 1.1 fvdl *
11 1.1 fvdl * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE
12 1.1 fvdl * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR
13 1.1 fvdl * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE.
14 1.1 fvdl *
15 1.1 fvdl * Sun RPC is provided with no support and without any obligation on the
16 1.1 fvdl * part of Sun Microsystems, Inc. to assist in its use, correction,
17 1.1 fvdl * modification or enhancement.
18 1.1 fvdl *
19 1.1 fvdl * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE
20 1.1 fvdl * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC
21 1.1 fvdl * OR ANY PART THEREOF.
22 1.1 fvdl *
23 1.1 fvdl * In no event will Sun Microsystems, Inc. be liable for any lost revenue
24 1.1 fvdl * or profits or other special, indirect and consequential damages, even if
25 1.1 fvdl * Sun has been advised of the possibility of such damages.
26 1.1 fvdl *
27 1.1 fvdl * Sun Microsystems, Inc.
28 1.1 fvdl * 2550 Garcia Avenue
29 1.1 fvdl * Mountain View, California 94043
30 1.1 fvdl */
31 1.1 fvdl /*
32 1.1 fvdl * Copyright (c) 1986-1991 by Sun Microsystems Inc.
33 1.1 fvdl */
34 1.1 fvdl
35 1.1 fvdl /* #pragma ident "@(#)rpc_generic.c 1.17 94/04/24 SMI" */
36 1.1 fvdl
37 1.1 fvdl /*
38 1.1 fvdl * rpc_generic.c, Miscl routines for RPC.
39 1.1 fvdl *
40 1.1 fvdl */
41 1.1 fvdl
42 1.15 itojun #include <sys/cdefs.h>
43 1.15 itojun #if defined(LIBC_SCCS) && !defined(lint)
44 1.25 christos __RCSID("$NetBSD: rpc_generic.c,v 1.25 2012/03/13 21:13:44 christos Exp $");
45 1.15 itojun #endif
46 1.15 itojun
47 1.4 kleink #include "namespace.h"
48 1.12 thorpej #include "reentrant.h"
49 1.1 fvdl #include <sys/types.h>
50 1.1 fvdl #include <sys/param.h>
51 1.1 fvdl #include <sys/socket.h>
52 1.1 fvdl #include <sys/un.h>
53 1.1 fvdl #include <sys/resource.h>
54 1.1 fvdl #include <netinet/in.h>
55 1.22 christos #include <netinet/tcp.h>
56 1.1 fvdl #include <arpa/inet.h>
57 1.1 fvdl #include <rpc/rpc.h>
58 1.5 lukem #include <assert.h>
59 1.1 fvdl #include <ctype.h>
60 1.1 fvdl #include <stdio.h>
61 1.1 fvdl #include <netdb.h>
62 1.1 fvdl #include <netconfig.h>
63 1.1 fvdl #include <malloc.h>
64 1.1 fvdl #include <string.h>
65 1.2 assar #include <syslog.h>
66 1.1 fvdl #include <rpc/nettype.h>
67 1.10 fvdl #include "rpc_internal.h"
68 1.1 fvdl
69 1.18 kleink #ifdef __weak_alias
70 1.18 kleink __weak_alias(taddr2uaddr,_taddr2uaddr)
71 1.18 kleink __weak_alias(uaddr2taddr,_uaddr2taddr)
72 1.18 kleink #endif
73 1.18 kleink
74 1.1 fvdl struct handle {
75 1.1 fvdl NCONF_HANDLE *nhandle;
76 1.1 fvdl int nflag; /* Whether NETPATH or NETCONFIG */
77 1.1 fvdl int nettype;
78 1.1 fvdl };
79 1.1 fvdl
80 1.6 jdolecek static const struct _rpcnettype {
81 1.1 fvdl const char *name;
82 1.1 fvdl const int type;
83 1.1 fvdl } _rpctypelist[] = {
84 1.1 fvdl { "netpath", _RPC_NETPATH },
85 1.1 fvdl { "visible", _RPC_VISIBLE },
86 1.1 fvdl { "circuit_v", _RPC_CIRCUIT_V },
87 1.1 fvdl { "datagram_v", _RPC_DATAGRAM_V },
88 1.1 fvdl { "circuit_n", _RPC_CIRCUIT_N },
89 1.1 fvdl { "datagram_n", _RPC_DATAGRAM_N },
90 1.1 fvdl { "tcp", _RPC_TCP },
91 1.1 fvdl { "udp", _RPC_UDP },
92 1.1 fvdl { 0, _RPC_NONE }
93 1.1 fvdl };
94 1.1 fvdl
95 1.1 fvdl struct netid_af {
96 1.1 fvdl const char *netid;
97 1.1 fvdl int af;
98 1.1 fvdl int protocol;
99 1.1 fvdl };
100 1.1 fvdl
101 1.6 jdolecek static const struct netid_af na_cvt[] = {
102 1.1 fvdl { "udp", AF_INET, IPPROTO_UDP },
103 1.1 fvdl { "tcp", AF_INET, IPPROTO_TCP },
104 1.1 fvdl #ifdef INET6
105 1.1 fvdl { "udp6", AF_INET6, IPPROTO_UDP },
106 1.1 fvdl { "tcp6", AF_INET6, IPPROTO_TCP },
107 1.1 fvdl #endif
108 1.1 fvdl { "local", AF_LOCAL, 0 }
109 1.1 fvdl };
110 1.1 fvdl
111 1.3 christos #if 0
112 1.1 fvdl static char *strlocase __P((char *));
113 1.3 christos #endif
114 1.3 christos static int getnettype __P((const char *));
115 1.1 fvdl
116 1.1 fvdl /*
117 1.1 fvdl * Cache the result of getrlimit(), so we don't have to do an
118 1.1 fvdl * expensive call every time.
119 1.1 fvdl */
120 1.1 fvdl int
121 1.1 fvdl __rpc_dtbsize()
122 1.1 fvdl {
123 1.1 fvdl static int tbsize;
124 1.1 fvdl struct rlimit rl;
125 1.1 fvdl
126 1.1 fvdl if (tbsize) {
127 1.1 fvdl return (tbsize);
128 1.1 fvdl }
129 1.1 fvdl if (getrlimit(RLIMIT_NOFILE, &rl) == 0) {
130 1.3 christos return (tbsize = (int)rl.rlim_max);
131 1.1 fvdl }
132 1.1 fvdl /*
133 1.1 fvdl * Something wrong. I'll try to save face by returning a
134 1.1 fvdl * pessimistic number.
135 1.1 fvdl */
136 1.1 fvdl return (32);
137 1.1 fvdl }
138 1.1 fvdl
139 1.1 fvdl
140 1.1 fvdl /*
141 1.1 fvdl * Find the appropriate buffer size
142 1.1 fvdl */
143 1.1 fvdl u_int
144 1.3 christos /*ARGSUSED*/
145 1.1 fvdl __rpc_get_t_size(af, proto, size)
146 1.1 fvdl int af, proto;
147 1.1 fvdl int size; /* Size requested */
148 1.1 fvdl {
149 1.13 yamt int maxsize, defsize;
150 1.1 fvdl
151 1.13 yamt maxsize = 256 * 1024; /* XXX */
152 1.1 fvdl switch (proto) {
153 1.1 fvdl case IPPROTO_TCP:
154 1.13 yamt defsize = 64 * 1024; /* XXX */
155 1.1 fvdl break;
156 1.1 fvdl case IPPROTO_UDP:
157 1.13 yamt defsize = UDPMSGSIZE;
158 1.1 fvdl break;
159 1.1 fvdl default:
160 1.13 yamt defsize = RPC_MAXDATASIZE;
161 1.1 fvdl break;
162 1.1 fvdl }
163 1.1 fvdl if (size == 0)
164 1.13 yamt return defsize;
165 1.1 fvdl
166 1.1 fvdl /* Check whether the value is within the upper max limit */
167 1.1 fvdl return (size > maxsize ? (u_int)maxsize : (u_int)size);
168 1.1 fvdl }
169 1.1 fvdl
170 1.1 fvdl /*
171 1.1 fvdl * Find the appropriate address buffer size
172 1.1 fvdl */
173 1.1 fvdl u_int
174 1.1 fvdl __rpc_get_a_size(af)
175 1.1 fvdl int af;
176 1.1 fvdl {
177 1.1 fvdl switch (af) {
178 1.1 fvdl case AF_INET:
179 1.1 fvdl return sizeof (struct sockaddr_in);
180 1.1 fvdl #ifdef INET6
181 1.1 fvdl case AF_INET6:
182 1.1 fvdl return sizeof (struct sockaddr_in6);
183 1.1 fvdl #endif
184 1.1 fvdl case AF_LOCAL:
185 1.1 fvdl return sizeof (struct sockaddr_un);
186 1.1 fvdl default:
187 1.1 fvdl break;
188 1.1 fvdl }
189 1.1 fvdl return ((u_int)RPC_MAXADDRSIZE);
190 1.1 fvdl }
191 1.1 fvdl
192 1.3 christos #if 0
193 1.1 fvdl static char *
194 1.1 fvdl strlocase(p)
195 1.1 fvdl char *p;
196 1.1 fvdl {
197 1.1 fvdl char *t = p;
198 1.1 fvdl
199 1.5 lukem _DIAGASSERT(p != NULL);
200 1.5 lukem
201 1.1 fvdl for (; *p; p++)
202 1.1 fvdl if (isupper(*p))
203 1.1 fvdl *p = tolower(*p);
204 1.1 fvdl return (t);
205 1.1 fvdl }
206 1.3 christos #endif
207 1.1 fvdl
208 1.1 fvdl /*
209 1.1 fvdl * Returns the type of the network as defined in <rpc/nettype.h>
210 1.1 fvdl * If nettype is NULL, it defaults to NETPATH.
211 1.1 fvdl */
212 1.1 fvdl static int
213 1.1 fvdl getnettype(nettype)
214 1.3 christos const char *nettype;
215 1.1 fvdl {
216 1.1 fvdl int i;
217 1.1 fvdl
218 1.16 fvdl if ((nettype == NULL) || (nettype[0] == 0)) {
219 1.1 fvdl return (_RPC_NETPATH); /* Default */
220 1.1 fvdl }
221 1.1 fvdl
222 1.3 christos #if 0
223 1.1 fvdl nettype = strlocase(nettype);
224 1.3 christos #endif
225 1.1 fvdl for (i = 0; _rpctypelist[i].name; i++)
226 1.3 christos if (strcasecmp(nettype, _rpctypelist[i].name) == 0) {
227 1.1 fvdl return (_rpctypelist[i].type);
228 1.1 fvdl }
229 1.1 fvdl return (_rpctypelist[i].type);
230 1.1 fvdl }
231 1.1 fvdl
232 1.1 fvdl /*
233 1.1 fvdl * For the given nettype (tcp or udp only), return the first structure found.
234 1.1 fvdl * This should be freed by calling freenetconfigent()
235 1.1 fvdl */
236 1.12 thorpej
237 1.12 thorpej #ifdef _REENTRANT
238 1.12 thorpej static thread_key_t tcp_key, udp_key;
239 1.12 thorpej static once_t __rpc_getconfigp_once = ONCE_INITIALIZER;
240 1.12 thorpej
241 1.12 thorpej static void
242 1.12 thorpej __rpc_getconfigp_setup(void)
243 1.12 thorpej {
244 1.12 thorpej
245 1.12 thorpej thr_keycreate(&tcp_key, free);
246 1.12 thorpej thr_keycreate(&udp_key, free);
247 1.12 thorpej }
248 1.12 thorpej #endif
249 1.12 thorpej
250 1.1 fvdl struct netconfig *
251 1.1 fvdl __rpc_getconfip(nettype)
252 1.3 christos const char *nettype;
253 1.1 fvdl {
254 1.1 fvdl char *netid;
255 1.23 christos char *netid_tcp = NULL;
256 1.23 christos char *netid_udp = NULL;
257 1.1 fvdl static char *netid_tcp_main;
258 1.1 fvdl static char *netid_udp_main;
259 1.1 fvdl struct netconfig *dummy;
260 1.12 thorpej #ifdef _REENTRANT
261 1.12 thorpej if (__isthreaded == 0) {
262 1.1 fvdl netid_udp = netid_udp_main;
263 1.1 fvdl netid_tcp = netid_tcp_main;
264 1.1 fvdl } else {
265 1.12 thorpej thr_once(&__rpc_getconfigp_once, __rpc_getconfigp_setup);
266 1.12 thorpej netid_tcp = thr_getspecific(tcp_key);
267 1.12 thorpej netid_udp = thr_getspecific(udp_key);
268 1.1 fvdl }
269 1.1 fvdl #else
270 1.1 fvdl netid_udp = netid_udp_main;
271 1.1 fvdl netid_tcp = netid_tcp_main;
272 1.1 fvdl #endif
273 1.5 lukem
274 1.5 lukem _DIAGASSERT(nettype != NULL);
275 1.5 lukem
276 1.1 fvdl if (!netid_udp && !netid_tcp) {
277 1.1 fvdl struct netconfig *nconf;
278 1.1 fvdl void *confighandle;
279 1.1 fvdl
280 1.1 fvdl if (!(confighandle = setnetconfig())) {
281 1.2 assar syslog (LOG_ERR, "rpc: failed to open " NETCONFIG);
282 1.1 fvdl return (NULL);
283 1.1 fvdl }
284 1.3 christos while ((nconf = getnetconfig(confighandle)) != NULL) {
285 1.1 fvdl if (strcmp(nconf->nc_protofmly, NC_INET) == 0) {
286 1.1 fvdl if (strcmp(nconf->nc_proto, NC_TCP) == 0) {
287 1.1 fvdl netid_tcp = strdup(nconf->nc_netid);
288 1.23 christos if (netid_tcp == NULL)
289 1.23 christos return NULL;
290 1.12 thorpej #ifdef _REENTRANT
291 1.12 thorpej if (__isthreaded == 0)
292 1.1 fvdl netid_tcp_main = netid_tcp;
293 1.1 fvdl else
294 1.1 fvdl thr_setspecific(tcp_key,
295 1.1 fvdl (void *) netid_tcp);
296 1.1 fvdl #else
297 1.1 fvdl netid_tcp_main = netid_tcp;
298 1.1 fvdl #endif
299 1.1 fvdl } else
300 1.1 fvdl if (strcmp(nconf->nc_proto, NC_UDP) == 0) {
301 1.1 fvdl netid_udp = strdup(nconf->nc_netid);
302 1.23 christos if (netid_udp == NULL)
303 1.23 christos return NULL;
304 1.12 thorpej #ifdef _REENTRANT
305 1.12 thorpej if (__isthreaded == 0)
306 1.1 fvdl netid_udp_main = netid_udp;
307 1.1 fvdl else
308 1.1 fvdl thr_setspecific(udp_key,
309 1.1 fvdl (void *) netid_udp);
310 1.1 fvdl #else
311 1.1 fvdl netid_udp_main = netid_udp;
312 1.1 fvdl #endif
313 1.1 fvdl }
314 1.1 fvdl }
315 1.1 fvdl }
316 1.1 fvdl endnetconfig(confighandle);
317 1.1 fvdl }
318 1.1 fvdl if (strcmp(nettype, "udp") == 0)
319 1.1 fvdl netid = netid_udp;
320 1.1 fvdl else if (strcmp(nettype, "tcp") == 0)
321 1.1 fvdl netid = netid_tcp;
322 1.1 fvdl else {
323 1.3 christos return (NULL);
324 1.1 fvdl }
325 1.16 fvdl if ((netid == NULL) || (netid[0] == 0)) {
326 1.3 christos return (NULL);
327 1.1 fvdl }
328 1.1 fvdl dummy = getnetconfigent(netid);
329 1.1 fvdl return (dummy);
330 1.1 fvdl }
331 1.1 fvdl
332 1.1 fvdl /*
333 1.1 fvdl * Returns the type of the nettype, which should then be used with
334 1.1 fvdl * __rpc_getconf().
335 1.1 fvdl */
336 1.1 fvdl void *
337 1.1 fvdl __rpc_setconf(nettype)
338 1.3 christos const char *nettype;
339 1.1 fvdl {
340 1.1 fvdl struct handle *handle;
341 1.1 fvdl
342 1.5 lukem /* nettype may be NULL; getnettype() supports that */
343 1.5 lukem
344 1.23 christos handle = malloc(sizeof(*handle));
345 1.1 fvdl if (handle == NULL) {
346 1.1 fvdl return (NULL);
347 1.1 fvdl }
348 1.1 fvdl switch (handle->nettype = getnettype(nettype)) {
349 1.1 fvdl case _RPC_NETPATH:
350 1.1 fvdl case _RPC_CIRCUIT_N:
351 1.1 fvdl case _RPC_DATAGRAM_N:
352 1.1 fvdl if (!(handle->nhandle = setnetpath())) {
353 1.1 fvdl free(handle);
354 1.1 fvdl return (NULL);
355 1.1 fvdl }
356 1.1 fvdl handle->nflag = TRUE;
357 1.1 fvdl break;
358 1.1 fvdl case _RPC_VISIBLE:
359 1.1 fvdl case _RPC_CIRCUIT_V:
360 1.1 fvdl case _RPC_DATAGRAM_V:
361 1.1 fvdl case _RPC_TCP:
362 1.1 fvdl case _RPC_UDP:
363 1.1 fvdl if (!(handle->nhandle = setnetconfig())) {
364 1.2 assar syslog (LOG_ERR, "rpc: failed to open " NETCONFIG);
365 1.1 fvdl free(handle);
366 1.1 fvdl return (NULL);
367 1.1 fvdl }
368 1.1 fvdl handle->nflag = FALSE;
369 1.1 fvdl break;
370 1.1 fvdl default:
371 1.21 christos free(handle);
372 1.1 fvdl return (NULL);
373 1.1 fvdl }
374 1.1 fvdl
375 1.1 fvdl return (handle);
376 1.1 fvdl }
377 1.1 fvdl
378 1.1 fvdl /*
379 1.1 fvdl * Returns the next netconfig struct for the given "net" type.
380 1.1 fvdl * __rpc_setconf() should have been called previously.
381 1.1 fvdl */
382 1.1 fvdl struct netconfig *
383 1.1 fvdl __rpc_getconf(vhandle)
384 1.1 fvdl void *vhandle;
385 1.1 fvdl {
386 1.1 fvdl struct handle *handle;
387 1.1 fvdl struct netconfig *nconf;
388 1.1 fvdl
389 1.1 fvdl handle = (struct handle *)vhandle;
390 1.1 fvdl if (handle == NULL) {
391 1.1 fvdl return (NULL);
392 1.1 fvdl }
393 1.3 christos for (;;) {
394 1.1 fvdl if (handle->nflag)
395 1.1 fvdl nconf = getnetpath(handle->nhandle);
396 1.1 fvdl else
397 1.1 fvdl nconf = getnetconfig(handle->nhandle);
398 1.3 christos if (nconf == NULL)
399 1.1 fvdl break;
400 1.1 fvdl if ((nconf->nc_semantics != NC_TPI_CLTS) &&
401 1.1 fvdl (nconf->nc_semantics != NC_TPI_COTS) &&
402 1.1 fvdl (nconf->nc_semantics != NC_TPI_COTS_ORD))
403 1.1 fvdl continue;
404 1.1 fvdl switch (handle->nettype) {
405 1.1 fvdl case _RPC_VISIBLE:
406 1.1 fvdl if (!(nconf->nc_flag & NC_VISIBLE))
407 1.1 fvdl continue;
408 1.1 fvdl /* FALLTHROUGH */
409 1.1 fvdl case _RPC_NETPATH: /* Be happy */
410 1.1 fvdl break;
411 1.1 fvdl case _RPC_CIRCUIT_V:
412 1.1 fvdl if (!(nconf->nc_flag & NC_VISIBLE))
413 1.1 fvdl continue;
414 1.1 fvdl /* FALLTHROUGH */
415 1.1 fvdl case _RPC_CIRCUIT_N:
416 1.1 fvdl if ((nconf->nc_semantics != NC_TPI_COTS) &&
417 1.1 fvdl (nconf->nc_semantics != NC_TPI_COTS_ORD))
418 1.1 fvdl continue;
419 1.1 fvdl break;
420 1.1 fvdl case _RPC_DATAGRAM_V:
421 1.1 fvdl if (!(nconf->nc_flag & NC_VISIBLE))
422 1.1 fvdl continue;
423 1.1 fvdl /* FALLTHROUGH */
424 1.1 fvdl case _RPC_DATAGRAM_N:
425 1.1 fvdl if (nconf->nc_semantics != NC_TPI_CLTS)
426 1.1 fvdl continue;
427 1.1 fvdl break;
428 1.1 fvdl case _RPC_TCP:
429 1.1 fvdl if (((nconf->nc_semantics != NC_TPI_COTS) &&
430 1.1 fvdl (nconf->nc_semantics != NC_TPI_COTS_ORD)) ||
431 1.1 fvdl (strcmp(nconf->nc_protofmly, NC_INET)
432 1.1 fvdl #ifdef INET6
433 1.1 fvdl && strcmp(nconf->nc_protofmly, NC_INET6))
434 1.1 fvdl #else
435 1.1 fvdl )
436 1.1 fvdl #endif
437 1.1 fvdl ||
438 1.1 fvdl strcmp(nconf->nc_proto, NC_TCP))
439 1.1 fvdl continue;
440 1.1 fvdl break;
441 1.1 fvdl case _RPC_UDP:
442 1.1 fvdl if ((nconf->nc_semantics != NC_TPI_CLTS) ||
443 1.1 fvdl (strcmp(nconf->nc_protofmly, NC_INET)
444 1.1 fvdl #ifdef INET6
445 1.1 fvdl && strcmp(nconf->nc_protofmly, NC_INET6))
446 1.1 fvdl #else
447 1.1 fvdl )
448 1.1 fvdl #endif
449 1.1 fvdl ||
450 1.1 fvdl strcmp(nconf->nc_proto, NC_UDP))
451 1.1 fvdl continue;
452 1.1 fvdl break;
453 1.1 fvdl }
454 1.1 fvdl break;
455 1.1 fvdl }
456 1.1 fvdl return (nconf);
457 1.1 fvdl }
458 1.1 fvdl
459 1.1 fvdl void
460 1.1 fvdl __rpc_endconf(vhandle)
461 1.1 fvdl void * vhandle;
462 1.1 fvdl {
463 1.1 fvdl struct handle *handle;
464 1.1 fvdl
465 1.1 fvdl handle = (struct handle *) vhandle;
466 1.1 fvdl if (handle == NULL) {
467 1.1 fvdl return;
468 1.1 fvdl }
469 1.1 fvdl if (handle->nflag) {
470 1.1 fvdl endnetpath(handle->nhandle);
471 1.1 fvdl } else {
472 1.1 fvdl endnetconfig(handle->nhandle);
473 1.1 fvdl }
474 1.1 fvdl free(handle);
475 1.1 fvdl }
476 1.1 fvdl
477 1.1 fvdl /*
478 1.1 fvdl * Used to ping the NULL procedure for clnt handle.
479 1.1 fvdl * Returns NULL if fails, else a non-NULL pointer.
480 1.1 fvdl */
481 1.1 fvdl void *
482 1.1 fvdl rpc_nullproc(clnt)
483 1.1 fvdl CLIENT *clnt;
484 1.1 fvdl {
485 1.1 fvdl struct timeval TIMEOUT = {25, 0};
486 1.1 fvdl
487 1.3 christos if (clnt_call(clnt, NULLPROC, (xdrproc_t) xdr_void, NULL,
488 1.3 christos (xdrproc_t) xdr_void, NULL, TIMEOUT) != RPC_SUCCESS) {
489 1.3 christos return (NULL);
490 1.1 fvdl }
491 1.1 fvdl return ((void *) clnt);
492 1.1 fvdl }
493 1.1 fvdl
494 1.1 fvdl /*
495 1.1 fvdl * Try all possible transports until
496 1.1 fvdl * one succeeds in finding the netconf for the given fd.
497 1.1 fvdl */
498 1.1 fvdl struct netconfig *
499 1.1 fvdl __rpcgettp(fd)
500 1.1 fvdl int fd;
501 1.1 fvdl {
502 1.1 fvdl const char *netid;
503 1.1 fvdl struct __rpc_sockinfo si;
504 1.1 fvdl
505 1.1 fvdl if (!__rpc_fd2sockinfo(fd, &si))
506 1.1 fvdl return NULL;
507 1.1 fvdl
508 1.1 fvdl if (!__rpc_sockinfo2netid(&si, &netid))
509 1.1 fvdl return NULL;
510 1.1 fvdl
511 1.20 christos return getnetconfigent(__UNCONST(netid));
512 1.1 fvdl }
513 1.1 fvdl
514 1.1 fvdl int
515 1.1 fvdl __rpc_fd2sockinfo(int fd, struct __rpc_sockinfo *sip)
516 1.1 fvdl {
517 1.1 fvdl socklen_t len;
518 1.1 fvdl int type, proto;
519 1.1 fvdl struct sockaddr_storage ss;
520 1.1 fvdl
521 1.5 lukem _DIAGASSERT(sip != NULL);
522 1.5 lukem
523 1.1 fvdl len = sizeof ss;
524 1.3 christos if (getsockname(fd, (struct sockaddr *)(void *)&ss, &len) < 0)
525 1.1 fvdl return 0;
526 1.1 fvdl sip->si_alen = len;
527 1.1 fvdl
528 1.1 fvdl len = sizeof type;
529 1.1 fvdl if (getsockopt(fd, SOL_SOCKET, SO_TYPE, &type, &len) < 0)
530 1.1 fvdl return 0;
531 1.1 fvdl
532 1.1 fvdl /* XXX */
533 1.1 fvdl if (ss.ss_family != AF_LOCAL) {
534 1.1 fvdl if (type == SOCK_STREAM)
535 1.1 fvdl proto = IPPROTO_TCP;
536 1.1 fvdl else if (type == SOCK_DGRAM)
537 1.1 fvdl proto = IPPROTO_UDP;
538 1.1 fvdl else
539 1.1 fvdl return 0;
540 1.1 fvdl } else
541 1.1 fvdl proto = 0;
542 1.1 fvdl
543 1.1 fvdl sip->si_af = ss.ss_family;
544 1.1 fvdl sip->si_proto = proto;
545 1.1 fvdl sip->si_socktype = type;
546 1.1 fvdl
547 1.1 fvdl return 1;
548 1.1 fvdl }
549 1.1 fvdl
550 1.1 fvdl /*
551 1.1 fvdl * Linear search, but the number of entries is small.
552 1.1 fvdl */
553 1.1 fvdl int
554 1.1 fvdl __rpc_nconf2sockinfo(const struct netconfig *nconf, struct __rpc_sockinfo *sip)
555 1.1 fvdl {
556 1.11 thorpej size_t i;
557 1.1 fvdl
558 1.5 lukem _DIAGASSERT(nconf != NULL);
559 1.5 lukem _DIAGASSERT(sip != NULL);
560 1.5 lukem
561 1.1 fvdl for (i = 0; i < (sizeof na_cvt) / (sizeof (struct netid_af)); i++)
562 1.1 fvdl if (!strcmp(na_cvt[i].netid, nconf->nc_netid)) {
563 1.1 fvdl sip->si_af = na_cvt[i].af;
564 1.1 fvdl sip->si_proto = na_cvt[i].protocol;
565 1.1 fvdl sip->si_socktype =
566 1.3 christos __rpc_seman2socktype((int)nconf->nc_semantics);
567 1.1 fvdl if (sip->si_socktype == -1)
568 1.1 fvdl return 0;
569 1.1 fvdl sip->si_alen = __rpc_get_a_size(sip->si_af);
570 1.1 fvdl return 1;
571 1.1 fvdl }
572 1.1 fvdl
573 1.1 fvdl return 0;
574 1.1 fvdl }
575 1.1 fvdl
576 1.1 fvdl int
577 1.1 fvdl __rpc_nconf2fd(const struct netconfig *nconf)
578 1.1 fvdl {
579 1.1 fvdl struct __rpc_sockinfo si;
580 1.1 fvdl
581 1.5 lukem _DIAGASSERT(nconf != NULL);
582 1.5 lukem
583 1.1 fvdl if (!__rpc_nconf2sockinfo(nconf, &si))
584 1.1 fvdl return 0;
585 1.1 fvdl
586 1.1 fvdl return socket(si.si_af, si.si_socktype, si.si_proto);
587 1.1 fvdl }
588 1.1 fvdl
589 1.1 fvdl int
590 1.1 fvdl __rpc_sockinfo2netid(struct __rpc_sockinfo *sip, const char **netid)
591 1.1 fvdl {
592 1.11 thorpej size_t i;
593 1.1 fvdl
594 1.5 lukem _DIAGASSERT(sip != NULL);
595 1.5 lukem /* netid may be NULL */
596 1.5 lukem
597 1.1 fvdl for (i = 0; i < (sizeof na_cvt) / (sizeof (struct netid_af)); i++)
598 1.1 fvdl if (na_cvt[i].af == sip->si_af &&
599 1.1 fvdl na_cvt[i].protocol == sip->si_proto) {
600 1.1 fvdl if (netid)
601 1.1 fvdl *netid = na_cvt[i].netid;
602 1.1 fvdl return 1;
603 1.1 fvdl }
604 1.1 fvdl
605 1.1 fvdl return 0;
606 1.1 fvdl }
607 1.1 fvdl
608 1.1 fvdl char *
609 1.1 fvdl taddr2uaddr(const struct netconfig *nconf, const struct netbuf *nbuf)
610 1.1 fvdl {
611 1.1 fvdl struct __rpc_sockinfo si;
612 1.1 fvdl
613 1.5 lukem _DIAGASSERT(nconf != NULL);
614 1.5 lukem _DIAGASSERT(nbuf != NULL);
615 1.5 lukem
616 1.1 fvdl if (!__rpc_nconf2sockinfo(nconf, &si))
617 1.1 fvdl return NULL;
618 1.1 fvdl return __rpc_taddr2uaddr_af(si.si_af, nbuf);
619 1.1 fvdl }
620 1.1 fvdl
621 1.1 fvdl struct netbuf *
622 1.1 fvdl uaddr2taddr(const struct netconfig *nconf, const char *uaddr)
623 1.1 fvdl {
624 1.1 fvdl struct __rpc_sockinfo si;
625 1.5 lukem
626 1.5 lukem _DIAGASSERT(nconf != NULL);
627 1.5 lukem _DIAGASSERT(uaddr != NULL);
628 1.1 fvdl
629 1.1 fvdl if (!__rpc_nconf2sockinfo(nconf, &si))
630 1.1 fvdl return NULL;
631 1.1 fvdl return __rpc_uaddr2taddr_af(si.si_af, uaddr);
632 1.1 fvdl }
633 1.1 fvdl
634 1.1 fvdl char *
635 1.1 fvdl __rpc_taddr2uaddr_af(int af, const struct netbuf *nbuf)
636 1.1 fvdl {
637 1.1 fvdl char *ret;
638 1.9 lukem struct sockaddr_in *sinp;
639 1.1 fvdl struct sockaddr_un *sun;
640 1.1 fvdl char namebuf[INET_ADDRSTRLEN];
641 1.1 fvdl #ifdef INET6
642 1.1 fvdl struct sockaddr_in6 *sin6;
643 1.1 fvdl char namebuf6[INET6_ADDRSTRLEN];
644 1.1 fvdl #endif
645 1.1 fvdl u_int16_t port;
646 1.1 fvdl
647 1.5 lukem _DIAGASSERT(nbuf != NULL);
648 1.5 lukem
649 1.1 fvdl switch (af) {
650 1.1 fvdl case AF_INET:
651 1.9 lukem sinp = nbuf->buf;
652 1.25 christos if (inet_ntop(af, &sinp->sin_addr, namebuf,
653 1.25 christos (socklen_t)sizeof namebuf) == NULL)
654 1.1 fvdl return NULL;
655 1.9 lukem port = ntohs(sinp->sin_port);
656 1.3 christos if (asprintf(&ret, "%s.%u.%u", namebuf, ((u_int32_t)port) >> 8,
657 1.3 christos port & 0xff) < 0)
658 1.1 fvdl return NULL;
659 1.1 fvdl break;
660 1.1 fvdl #ifdef INET6
661 1.1 fvdl case AF_INET6:
662 1.1 fvdl sin6 = nbuf->buf;
663 1.25 christos if (inet_ntop(af, &sin6->sin6_addr, namebuf6,
664 1.25 christos (socklen_t)sizeof namebuf6) == NULL)
665 1.1 fvdl return NULL;
666 1.1 fvdl port = ntohs(sin6->sin6_port);
667 1.3 christos if (asprintf(&ret, "%s.%u.%u", namebuf6, ((u_int32_t)port) >> 8,
668 1.3 christos port & 0xff) < 0)
669 1.1 fvdl return NULL;
670 1.1 fvdl break;
671 1.1 fvdl #endif
672 1.1 fvdl case AF_LOCAL:
673 1.1 fvdl sun = nbuf->buf;
674 1.1 fvdl sun->sun_path[sizeof(sun->sun_path) - 1] = '\0'; /* safety */
675 1.1 fvdl ret = strdup(sun->sun_path);
676 1.1 fvdl break;
677 1.1 fvdl default:
678 1.1 fvdl return NULL;
679 1.1 fvdl }
680 1.1 fvdl
681 1.1 fvdl return ret;
682 1.1 fvdl }
683 1.1 fvdl
684 1.1 fvdl struct netbuf *
685 1.1 fvdl __rpc_uaddr2taddr_af(int af, const char *uaddr)
686 1.1 fvdl {
687 1.1 fvdl struct netbuf *ret = NULL;
688 1.1 fvdl char *addrstr, *p;
689 1.1 fvdl unsigned port, portlo, porthi;
690 1.25 christos size_t len;
691 1.9 lukem struct sockaddr_in *sinp;
692 1.1 fvdl #ifdef INET6
693 1.1 fvdl struct sockaddr_in6 *sin6;
694 1.1 fvdl #endif
695 1.1 fvdl struct sockaddr_un *sun;
696 1.1 fvdl
697 1.5 lukem _DIAGASSERT(uaddr != NULL);
698 1.5 lukem
699 1.1 fvdl addrstr = strdup(uaddr);
700 1.1 fvdl if (addrstr == NULL)
701 1.1 fvdl return NULL;
702 1.1 fvdl
703 1.1 fvdl /*
704 1.1 fvdl * AF_LOCAL addresses are expected to be absolute
705 1.1 fvdl * pathnames, anything else will be AF_INET or AF_INET6.
706 1.1 fvdl */
707 1.19 lukem port = 0;
708 1.1 fvdl if (*addrstr != '/') {
709 1.1 fvdl p = strrchr(addrstr, '.');
710 1.1 fvdl if (p == NULL)
711 1.1 fvdl goto out;
712 1.1 fvdl portlo = (unsigned)atoi(p + 1);
713 1.1 fvdl *p = '\0';
714 1.1 fvdl
715 1.1 fvdl p = strrchr(addrstr, '.');
716 1.1 fvdl if (p == NULL)
717 1.1 fvdl goto out;
718 1.1 fvdl porthi = (unsigned)atoi(p + 1);
719 1.1 fvdl *p = '\0';
720 1.1 fvdl port = (porthi << 8) | portlo;
721 1.1 fvdl }
722 1.1 fvdl
723 1.23 christos ret = malloc(sizeof(*ret));
724 1.8 kristerw if (ret == NULL)
725 1.8 kristerw goto out;
726 1.1 fvdl
727 1.1 fvdl switch (af) {
728 1.1 fvdl case AF_INET:
729 1.23 christos sinp = malloc(sizeof(*sinp));
730 1.9 lukem if (sinp == NULL)
731 1.1 fvdl goto out;
732 1.9 lukem memset(sinp, 0, sizeof *sinp);
733 1.9 lukem sinp->sin_family = AF_INET;
734 1.9 lukem sinp->sin_port = htons(port);
735 1.9 lukem if (inet_pton(AF_INET, addrstr, &sinp->sin_addr) <= 0) {
736 1.9 lukem free(sinp);
737 1.1 fvdl free(ret);
738 1.1 fvdl ret = NULL;
739 1.1 fvdl goto out;
740 1.1 fvdl }
741 1.9 lukem sinp->sin_len = ret->maxlen = ret->len = sizeof *sinp;
742 1.9 lukem ret->buf = sinp;
743 1.1 fvdl break;
744 1.1 fvdl #ifdef INET6
745 1.1 fvdl case AF_INET6:
746 1.23 christos sin6 = malloc(sizeof(*sin6));
747 1.1 fvdl if (sin6 == NULL)
748 1.1 fvdl goto out;
749 1.1 fvdl memset(sin6, 0, sizeof *sin6);
750 1.1 fvdl sin6->sin6_family = AF_INET6;
751 1.1 fvdl sin6->sin6_port = htons(port);
752 1.1 fvdl if (inet_pton(AF_INET6, addrstr, &sin6->sin6_addr) <= 0) {
753 1.8 kristerw free(sin6);
754 1.1 fvdl free(ret);
755 1.1 fvdl ret = NULL;
756 1.1 fvdl goto out;
757 1.1 fvdl }
758 1.1 fvdl sin6->sin6_len = ret->maxlen = ret->len = sizeof *sin6;
759 1.1 fvdl ret->buf = sin6;
760 1.1 fvdl break;
761 1.1 fvdl #endif
762 1.1 fvdl case AF_LOCAL:
763 1.23 christos sun = malloc(sizeof(*sun));
764 1.1 fvdl if (sun == NULL)
765 1.1 fvdl goto out;
766 1.1 fvdl memset(sun, 0, sizeof *sun);
767 1.1 fvdl sun->sun_family = AF_LOCAL;
768 1.1 fvdl strncpy(sun->sun_path, addrstr, sizeof(sun->sun_path) - 1);
769 1.25 christos len = SUN_LEN(sun);
770 1.25 christos _DIAGASSERT(__type_fit(uint8_t, len));
771 1.25 christos ret->len = ret->maxlen = sun->sun_len = (uint8_t)len;
772 1.7 fvdl ret->buf = sun;
773 1.3 christos break;
774 1.1 fvdl default:
775 1.1 fvdl break;
776 1.1 fvdl }
777 1.1 fvdl out:
778 1.1 fvdl free(addrstr);
779 1.1 fvdl return ret;
780 1.1 fvdl }
781 1.1 fvdl
782 1.1 fvdl int
783 1.1 fvdl __rpc_seman2socktype(int semantics)
784 1.1 fvdl {
785 1.1 fvdl switch (semantics) {
786 1.1 fvdl case NC_TPI_CLTS:
787 1.1 fvdl return SOCK_DGRAM;
788 1.1 fvdl case NC_TPI_COTS_ORD:
789 1.1 fvdl return SOCK_STREAM;
790 1.1 fvdl case NC_TPI_RAW:
791 1.1 fvdl return SOCK_RAW;
792 1.1 fvdl default:
793 1.1 fvdl break;
794 1.1 fvdl }
795 1.1 fvdl
796 1.1 fvdl return -1;
797 1.1 fvdl }
798 1.1 fvdl
799 1.1 fvdl int
800 1.1 fvdl __rpc_socktype2seman(int socktype)
801 1.1 fvdl {
802 1.1 fvdl switch (socktype) {
803 1.1 fvdl case SOCK_DGRAM:
804 1.1 fvdl return NC_TPI_CLTS;
805 1.1 fvdl case SOCK_STREAM:
806 1.1 fvdl return NC_TPI_COTS_ORD;
807 1.1 fvdl case SOCK_RAW:
808 1.1 fvdl return NC_TPI_RAW;
809 1.1 fvdl default:
810 1.1 fvdl break;
811 1.1 fvdl }
812 1.1 fvdl
813 1.1 fvdl return -1;
814 1.1 fvdl }
815 1.1 fvdl
816 1.1 fvdl /*
817 1.1 fvdl * XXXX - IPv6 scope IDs can't be handled in universal addresses.
818 1.1 fvdl * Here, we compare the original server address to that of the RPC
819 1.1 fvdl * service we just received back from a call to rpcbind on the remote
820 1.1 fvdl * machine. If they are both "link local" or "site local", copy
821 1.1 fvdl * the scope id of the server address over to the service address.
822 1.1 fvdl */
823 1.17 lukem /* ARGSUSED */
824 1.1 fvdl int
825 1.1 fvdl __rpc_fixup_addr(struct netbuf *new, const struct netbuf *svc)
826 1.1 fvdl {
827 1.1 fvdl #ifdef INET6
828 1.1 fvdl struct sockaddr *sa_new, *sa_svc;
829 1.1 fvdl struct sockaddr_in6 *sin6_new, *sin6_svc;
830 1.5 lukem
831 1.5 lukem _DIAGASSERT(new != NULL);
832 1.5 lukem _DIAGASSERT(svc != NULL);
833 1.1 fvdl
834 1.1 fvdl sa_svc = (struct sockaddr *)svc->buf;
835 1.1 fvdl sa_new = (struct sockaddr *)new->buf;
836 1.1 fvdl
837 1.1 fvdl if (sa_new->sa_family == sa_svc->sa_family &&
838 1.1 fvdl sa_new->sa_family == AF_INET6) {
839 1.1 fvdl sin6_new = (struct sockaddr_in6 *)new->buf;
840 1.1 fvdl sin6_svc = (struct sockaddr_in6 *)svc->buf;
841 1.1 fvdl
842 1.1 fvdl if ((IN6_IS_ADDR_LINKLOCAL(&sin6_new->sin6_addr) &&
843 1.1 fvdl IN6_IS_ADDR_LINKLOCAL(&sin6_svc->sin6_addr)) ||
844 1.1 fvdl (IN6_IS_ADDR_SITELOCAL(&sin6_new->sin6_addr) &&
845 1.1 fvdl IN6_IS_ADDR_SITELOCAL(&sin6_svc->sin6_addr))) {
846 1.1 fvdl sin6_new->sin6_scope_id = sin6_svc->sin6_scope_id;
847 1.1 fvdl }
848 1.1 fvdl }
849 1.1 fvdl #endif
850 1.1 fvdl return 1;
851 1.1 fvdl }
852 1.1 fvdl
853 1.1 fvdl int
854 1.1 fvdl __rpc_sockisbound(int fd)
855 1.1 fvdl {
856 1.1 fvdl struct sockaddr_storage ss;
857 1.1 fvdl socklen_t slen;
858 1.1 fvdl
859 1.1 fvdl slen = sizeof (struct sockaddr_storage);
860 1.3 christos if (getsockname(fd, (struct sockaddr *)(void *)&ss, &slen) < 0)
861 1.1 fvdl return 0;
862 1.1 fvdl
863 1.1 fvdl switch (ss.ss_family) {
864 1.1 fvdl case AF_INET:
865 1.3 christos return (((struct sockaddr_in *)
866 1.3 christos (void *)&ss)->sin_port != 0);
867 1.1 fvdl #ifdef INET6
868 1.1 fvdl case AF_INET6:
869 1.3 christos return (((struct sockaddr_in6 *)
870 1.3 christos (void *)&ss)->sin6_port != 0);
871 1.1 fvdl #endif
872 1.1 fvdl case AF_LOCAL:
873 1.1 fvdl /* XXX check this */
874 1.3 christos return (((struct sockaddr_un *)
875 1.3 christos (void *)&ss)->sun_path[0] != '\0');
876 1.1 fvdl default:
877 1.1 fvdl break;
878 1.1 fvdl }
879 1.1 fvdl
880 1.1 fvdl return 0;
881 1.1 fvdl }
882 1.22 christos
883 1.22 christos /*
884 1.22 christos * For TCP transport, Host Requirements RFCs mandate
885 1.22 christos * Nagle (RFC-896) processing. But for RPC, Nagle
886 1.22 christos * processing adds adds unwanted latency to the last,
887 1.22 christos * partial TCP segment of each RPC message. See:
888 1.22 christos * R. W. Scheifler and J. Gettys, The X Window System,
889 1.22 christos * ACM Transactions on Graphics 16:8 (Aug. 1983), pp. 57-69.
890 1.22 christos * So for TCP transport, disable Nagle via TCP_NODELAY.
891 1.22 christos * XXX: moral equivalent for non-TCP protocols?
892 1.22 christos */
893 1.22 christos int
894 1.22 christos __rpc_setnodelay(int fd, const struct __rpc_sockinfo *si)
895 1.22 christos {
896 1.22 christos int one = 1;
897 1.22 christos if (si->si_proto != IPPROTO_TCP)
898 1.22 christos return 0;
899 1.25 christos return setsockopt(fd, si->si_proto, TCP_NODELAY, &one,
900 1.25 christos (socklen_t)sizeof(one));
901 1.22 christos }
902