nfsd.c revision 1.51 1 1.51 yamt /* $NetBSD: nfsd.c,v 1.51 2007/07/11 04:59:19 yamt Exp $ */
2 1.16 cgd
3 1.1 cgd /*
4 1.11 mycroft * Copyright (c) 1989, 1993, 1994
5 1.11 mycroft * The Regents of the University of California. All rights reserved.
6 1.1 cgd *
7 1.1 cgd * This code is derived from software contributed to Berkeley by
8 1.1 cgd * Rick Macklem at The University of Guelph.
9 1.1 cgd *
10 1.1 cgd * Redistribution and use in source and binary forms, with or without
11 1.1 cgd * modification, are permitted provided that the following conditions
12 1.1 cgd * are met:
13 1.1 cgd * 1. Redistributions of source code must retain the above copyright
14 1.1 cgd * notice, this list of conditions and the following disclaimer.
15 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 cgd * notice, this list of conditions and the following disclaimer in the
17 1.1 cgd * documentation and/or other materials provided with the distribution.
18 1.43 agc * 3. Neither the name of the University nor the names of its contributors
19 1.1 cgd * may be used to endorse or promote products derived from this software
20 1.1 cgd * without specific prior written permission.
21 1.1 cgd *
22 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
23 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
24 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
25 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
26 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
27 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
28 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
29 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
30 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
31 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
32 1.1 cgd * SUCH DAMAGE.
33 1.1 cgd */
34 1.1 cgd
35 1.23 lukem #include <sys/cdefs.h>
36 1.1 cgd #ifndef lint
37 1.23 lukem __COPYRIGHT("@(#) Copyright (c) 1989, 1993, 1994\n\
38 1.23 lukem The Regents of the University of California. All rights reserved.\n");
39 1.35 cgd #endif /* not lint */
40 1.1 cgd
41 1.1 cgd #ifndef lint
42 1.16 cgd #if 0
43 1.18 fvdl static char sccsid[] = "@(#)nfsd.c 8.9 (Berkeley) 3/29/95";
44 1.16 cgd #else
45 1.51 yamt __RCSID("$NetBSD: nfsd.c,v 1.51 2007/07/11 04:59:19 yamt Exp $");
46 1.16 cgd #endif
47 1.18 fvdl #endif /* not lint */
48 1.1 cgd
49 1.11 mycroft #include <sys/param.h>
50 1.1 cgd #include <sys/ioctl.h>
51 1.1 cgd #include <sys/stat.h>
52 1.1 cgd #include <sys/wait.h>
53 1.11 mycroft #include <sys/uio.h>
54 1.11 mycroft #include <sys/ucred.h>
55 1.1 cgd #include <sys/mount.h>
56 1.1 cgd #include <sys/socket.h>
57 1.1 cgd #include <sys/socketvar.h>
58 1.39 itojun #include <poll.h>
59 1.11 mycroft
60 1.1 cgd #include <rpc/rpc.h>
61 1.1 cgd #include <rpc/pmap_clnt.h>
62 1.1 cgd #include <rpc/pmap_prot.h>
63 1.11 mycroft
64 1.11 mycroft #ifdef ISO
65 1.11 mycroft #include <netiso/iso.h>
66 1.11 mycroft #endif
67 1.1 cgd #include <nfs/rpcv2.h>
68 1.18 fvdl #include <nfs/nfsproto.h>
69 1.11 mycroft #include <nfs/nfs.h>
70 1.11 mycroft
71 1.11 mycroft #include <err.h>
72 1.11 mycroft #include <errno.h>
73 1.11 mycroft #include <fcntl.h>
74 1.11 mycroft #include <grp.h>
75 1.11 mycroft #include <pwd.h>
76 1.50 yamt #include <pthread.h>
77 1.11 mycroft #include <signal.h>
78 1.11 mycroft #include <stdio.h>
79 1.11 mycroft #include <stdlib.h>
80 1.25 perry #include <string.h>
81 1.19 mycroft #include <syslog.h>
82 1.11 mycroft #include <unistd.h>
83 1.32 fvdl #include <netdb.h>
84 1.1 cgd
85 1.1 cgd /* Global defs */
86 1.1 cgd #ifdef DEBUG
87 1.1 cgd #define syslog(e, s) fprintf(stderr,(s))
88 1.1 cgd int debug = 1;
89 1.1 cgd #else
90 1.1 cgd int debug = 0;
91 1.1 cgd #endif
92 1.11 mycroft
93 1.23 lukem int main __P((int, char **));
94 1.11 mycroft void nonfs __P((int));
95 1.11 mycroft void usage __P((void));
96 1.1 cgd
97 1.50 yamt static void *
98 1.50 yamt child(void *dummy)
99 1.50 yamt {
100 1.50 yamt struct nfsd_srvargs nsd;
101 1.50 yamt int nfssvc_flag;
102 1.50 yamt
103 1.51 yamt pthread_setname_np(pthread_self(), "slave", NULL);
104 1.50 yamt nfssvc_flag = NFSSVC_NFSD;
105 1.50 yamt memset(&nsd, 0, sizeof(nsd));
106 1.50 yamt while (nfssvc(nfssvc_flag, &nsd) < 0) {
107 1.50 yamt if (errno != ENEEDAUTH) {
108 1.50 yamt syslog(LOG_ERR, "nfssvc: %m");
109 1.50 yamt exit(1);
110 1.50 yamt }
111 1.50 yamt nfssvc_flag = NFSSVC_NFSD | NFSSVC_AUTHINFAIL;
112 1.50 yamt }
113 1.50 yamt
114 1.50 yamt return NULL;
115 1.50 yamt }
116 1.50 yamt
117 1.1 cgd /*
118 1.1 cgd * Nfs server daemon mostly just a user context for nfssvc()
119 1.11 mycroft *
120 1.1 cgd * 1 - do file descriptor and signal cleanup
121 1.50 yamt * 2 - create the nfsd thread(s)
122 1.11 mycroft * 3 - create server socket(s)
123 1.11 mycroft * 4 - register socket with portmap
124 1.11 mycroft *
125 1.28 lukem * For connectionless protocols, just pass the socket into the kernel via
126 1.11 mycroft * nfssvc().
127 1.11 mycroft * For connection based sockets, loop doing accepts. When you get a new
128 1.28 lukem * socket from accept, pass the msgsock into the kernel via nfssvc().
129 1.1 cgd * The arguments are:
130 1.11 mycroft * -c - support iso cltp clients
131 1.11 mycroft * -r - reregister with portmapper
132 1.11 mycroft * -t - support tcp nfs clients
133 1.11 mycroft * -u - support udp nfs clients
134 1.50 yamt * followed by "n" which is the number of nfsd threads to create
135 1.1 cgd */
136 1.11 mycroft int
137 1.23 lukem main(argc, argv)
138 1.1 cgd int argc;
139 1.23 lukem char *argv[];
140 1.1 cgd {
141 1.11 mycroft struct nfsd_args nfsdargs;
142 1.32 fvdl struct addrinfo *ai_udp, *ai_tcp, *ai_udp6, *ai_tcp6, hints;
143 1.32 fvdl struct netconfig *nconf_udp, *nconf_tcp, *nconf_udp6, *nconf_tcp6;
144 1.32 fvdl struct netbuf nb_udp, nb_tcp, nb_udp6, nb_tcp6;
145 1.32 fvdl struct sockaddr_in inetpeer;
146 1.32 fvdl struct sockaddr_in6 inet6peer;
147 1.11 mycroft #ifdef ISO
148 1.11 mycroft struct sockaddr_iso isoaddr, isopeer;
149 1.11 mycroft #endif
150 1.37 mycroft struct pollfd set[4];
151 1.47 mrg socklen_t len;
152 1.47 mrg int ch, cltpflag, connect_type_cnt, i, maxsock, msgsock;
153 1.50 yamt int nfsdcnt, on = 1, reregister, sock, tcpflag, tcpsock;
154 1.32 fvdl int tcp6sock, ip6flag;
155 1.32 fvdl int tp4cnt, tp4flag, tpipcnt, tpipflag, udpflag, ecode, s;
156 1.11 mycroft
157 1.44 jonathan #define MAXNFSDCNT 1024
158 1.11 mycroft #define DEFNFSDCNT 4
159 1.11 mycroft nfsdcnt = DEFNFSDCNT;
160 1.11 mycroft cltpflag = reregister = tcpflag = tp4cnt = tp4flag = tpipcnt = 0;
161 1.32 fvdl tpipflag = udpflag = ip6flag = 0;
162 1.45 lukem nconf_udp = nconf_tcp = nconf_udp6 = nconf_tcp6 = NULL;
163 1.45 lukem maxsock = 0;
164 1.45 lukem tcpsock = tcp6sock = -1;
165 1.11 mycroft #ifdef ISO
166 1.32 fvdl #define GETOPT "6cn:rtu"
167 1.11 mycroft #define USAGE "[-crtu] [-n num_servers]"
168 1.11 mycroft #else
169 1.32 fvdl #define GETOPT "6n:rtu"
170 1.11 mycroft #define USAGE "[-rtu] [-n num_servers]"
171 1.11 mycroft #endif
172 1.30 thorpej while ((ch = getopt(argc, argv, GETOPT)) != -1) {
173 1.11 mycroft switch (ch) {
174 1.32 fvdl case '6':
175 1.32 fvdl ip6flag = 1;
176 1.32 fvdl s = socket(PF_INET6, SOCK_DGRAM, IPPROTO_UDP);
177 1.32 fvdl if (s < 0 && (errno == EPROTONOSUPPORT ||
178 1.32 fvdl errno == EPFNOSUPPORT || errno == EAFNOSUPPORT))
179 1.32 fvdl ip6flag = 0;
180 1.32 fvdl else
181 1.32 fvdl close(s);
182 1.32 fvdl break;
183 1.11 mycroft case 'n':
184 1.11 mycroft nfsdcnt = atoi(optarg);
185 1.11 mycroft if (nfsdcnt < 1 || nfsdcnt > MAXNFSDCNT) {
186 1.21 fvdl warnx("nfsd count %d; reset to %d", nfsdcnt, DEFNFSDCNT);
187 1.11 mycroft nfsdcnt = DEFNFSDCNT;
188 1.11 mycroft }
189 1.11 mycroft break;
190 1.1 cgd case 'r':
191 1.11 mycroft reregister = 1;
192 1.1 cgd break;
193 1.1 cgd case 't':
194 1.11 mycroft tcpflag = 1;
195 1.1 cgd break;
196 1.1 cgd case 'u':
197 1.11 mycroft udpflag = 1;
198 1.11 mycroft break;
199 1.11 mycroft #ifdef ISO
200 1.11 mycroft case 'c':
201 1.11 mycroft cltpflag = 1;
202 1.1 cgd break;
203 1.11 mycroft #ifdef notyet
204 1.11 mycroft case 'i':
205 1.11 mycroft tp4cnt = 1;
206 1.11 mycroft break;
207 1.11 mycroft case 'p':
208 1.11 mycroft tpipcnt = 1;
209 1.11 mycroft break;
210 1.11 mycroft #endif /* notyet */
211 1.11 mycroft #endif /* ISO */
212 1.1 cgd default:
213 1.1 cgd case '?':
214 1.1 cgd usage();
215 1.11 mycroft };
216 1.30 thorpej }
217 1.11 mycroft argv += optind;
218 1.11 mycroft argc -= optind;
219 1.1 cgd
220 1.1 cgd /*
221 1.11 mycroft * XXX
222 1.11 mycroft * Backward compatibility, trailing number is the count of daemons.
223 1.1 cgd */
224 1.11 mycroft if (argc > 1)
225 1.11 mycroft usage();
226 1.11 mycroft if (argc == 1) {
227 1.11 mycroft nfsdcnt = atoi(argv[0]);
228 1.11 mycroft if (nfsdcnt < 1 || nfsdcnt > MAXNFSDCNT) {
229 1.21 fvdl warnx("nfsd count %d; reset to %d", nfsdcnt, DEFNFSDCNT);
230 1.11 mycroft nfsdcnt = DEFNFSDCNT;
231 1.11 mycroft }
232 1.1 cgd }
233 1.31 soren
234 1.31 soren /*
235 1.31 soren * If none of TCP or UDP are specified, default to UDP only.
236 1.31 soren */
237 1.31 soren if (tcpflag == 0 && udpflag == 0)
238 1.31 soren udpflag = 1;
239 1.1 cgd
240 1.1 cgd if (debug == 0) {
241 1.1 cgd daemon(0, 0);
242 1.11 mycroft (void)signal(SIGHUP, SIG_IGN);
243 1.11 mycroft (void)signal(SIGINT, SIG_IGN);
244 1.11 mycroft (void)signal(SIGQUIT, SIG_IGN);
245 1.11 mycroft (void)signal(SIGSYS, nonfs);
246 1.1 cgd }
247 1.11 mycroft
248 1.32 fvdl if (udpflag) {
249 1.32 fvdl memset(&hints, 0, sizeof hints);
250 1.32 fvdl hints.ai_flags = AI_PASSIVE;
251 1.32 fvdl hints.ai_family = PF_INET;
252 1.32 fvdl hints.ai_socktype = SOCK_DGRAM;
253 1.32 fvdl hints.ai_protocol = IPPROTO_UDP;
254 1.32 fvdl
255 1.32 fvdl ecode = getaddrinfo(NULL, "nfs", &hints, &ai_udp);
256 1.32 fvdl if (ecode != 0) {
257 1.32 fvdl syslog(LOG_ERR, "getaddrinfo udp: %s",
258 1.32 fvdl gai_strerror(ecode));
259 1.32 fvdl exit(1);
260 1.32 fvdl }
261 1.32 fvdl
262 1.32 fvdl nconf_udp = getnetconfigent("udp");
263 1.32 fvdl
264 1.32 fvdl if (nconf_udp == NULL)
265 1.32 fvdl err(1, "getnetconfigent udp failed");
266 1.32 fvdl
267 1.32 fvdl nb_udp.buf = ai_udp->ai_addr;
268 1.32 fvdl nb_udp.len = nb_udp.maxlen = ai_udp->ai_addrlen;
269 1.32 fvdl if (reregister)
270 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp, &nb_udp))
271 1.32 fvdl err(1, "rpcb_set udp failed");
272 1.32 fvdl }
273 1.32 fvdl
274 1.32 fvdl if (tcpflag) {
275 1.32 fvdl memset(&hints, 0, sizeof hints);
276 1.32 fvdl hints.ai_flags = AI_PASSIVE;
277 1.32 fvdl hints.ai_family = PF_INET;
278 1.32 fvdl hints.ai_socktype = SOCK_STREAM;
279 1.32 fvdl hints.ai_protocol = IPPROTO_TCP;
280 1.32 fvdl
281 1.32 fvdl ecode = getaddrinfo(NULL, "nfs", &hints, &ai_tcp);
282 1.32 fvdl if (ecode != 0) {
283 1.48 hubertf syslog(LOG_ERR, "getaddrinfo tcp: %s",
284 1.32 fvdl gai_strerror(ecode));
285 1.32 fvdl exit(1);
286 1.32 fvdl }
287 1.32 fvdl
288 1.32 fvdl nconf_tcp = getnetconfigent("tcp");
289 1.32 fvdl
290 1.32 fvdl if (nconf_tcp == NULL)
291 1.32 fvdl err(1, "getnetconfigent tcp failed");
292 1.32 fvdl
293 1.32 fvdl nb_tcp.buf = ai_tcp->ai_addr;
294 1.32 fvdl nb_tcp.len = nb_tcp.maxlen = ai_tcp->ai_addrlen;
295 1.32 fvdl if (reregister)
296 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp, &nb_tcp))
297 1.32 fvdl err(1, "rpcb_set tcp failed");
298 1.32 fvdl }
299 1.32 fvdl
300 1.32 fvdl if (udpflag && ip6flag) {
301 1.32 fvdl memset(&hints, 0, sizeof hints);
302 1.32 fvdl hints.ai_flags = AI_PASSIVE;
303 1.32 fvdl hints.ai_family = PF_INET6;
304 1.32 fvdl hints.ai_socktype = SOCK_DGRAM;
305 1.32 fvdl hints.ai_protocol = IPPROTO_UDP;
306 1.32 fvdl
307 1.32 fvdl ecode = getaddrinfo(NULL, "nfs", &hints, &ai_udp6);
308 1.32 fvdl if (ecode != 0) {
309 1.32 fvdl syslog(LOG_ERR, "getaddrinfo udp: %s",
310 1.32 fvdl gai_strerror(ecode));
311 1.32 fvdl exit(1);
312 1.32 fvdl }
313 1.32 fvdl
314 1.32 fvdl nconf_udp6 = getnetconfigent("udp6");
315 1.32 fvdl
316 1.32 fvdl if (nconf_udp6 == NULL)
317 1.32 fvdl err(1, "getnetconfigent udp6 failed");
318 1.32 fvdl
319 1.32 fvdl nb_udp6.buf = ai_udp6->ai_addr;
320 1.32 fvdl nb_udp6.len = nb_udp6.maxlen = ai_udp6->ai_addrlen;
321 1.32 fvdl if (reregister)
322 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp6, &nb_udp6))
323 1.32 fvdl err(1, "rpcb_set udp6 failed");
324 1.32 fvdl }
325 1.32 fvdl
326 1.32 fvdl if (tcpflag && ip6flag) {
327 1.32 fvdl memset(&hints, 0, sizeof hints);
328 1.32 fvdl hints.ai_flags = AI_PASSIVE;
329 1.32 fvdl hints.ai_family = PF_INET6;
330 1.32 fvdl hints.ai_socktype = SOCK_STREAM;
331 1.32 fvdl hints.ai_protocol = IPPROTO_TCP;
332 1.32 fvdl
333 1.32 fvdl ecode = getaddrinfo(NULL, "nfs", &hints, &ai_tcp6);
334 1.32 fvdl if (ecode != 0) {
335 1.48 hubertf syslog(LOG_ERR, "getaddrinfo tcp: %s",
336 1.32 fvdl gai_strerror(ecode));
337 1.32 fvdl exit(1);
338 1.32 fvdl }
339 1.32 fvdl
340 1.32 fvdl nconf_tcp6 = getnetconfigent("tcp6");
341 1.32 fvdl
342 1.32 fvdl if (nconf_tcp6 == NULL)
343 1.32 fvdl err(1, "getnetconfigent tcp6 failed");
344 1.32 fvdl
345 1.32 fvdl nb_tcp6.buf = ai_tcp6->ai_addr;
346 1.32 fvdl nb_tcp6.len = nb_tcp6.maxlen = ai_tcp6->ai_addrlen;
347 1.32 fvdl if (reregister)
348 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp6, &nb_tcp6))
349 1.32 fvdl err(1, "rpcb_set tcp6 failed");
350 1.8 cgd }
351 1.32 fvdl
352 1.33 lukem openlog("nfsd", LOG_PID, LOG_DAEMON);
353 1.11 mycroft
354 1.11 mycroft for (i = 0; i < nfsdcnt; i++) {
355 1.50 yamt pthread_t t;
356 1.50 yamt int error;
357 1.50 yamt
358 1.50 yamt error = pthread_create(&t, NULL, child, NULL);
359 1.50 yamt if (error) {
360 1.50 yamt errno = error;
361 1.50 yamt syslog(LOG_ERR, "pthread_create: %m");
362 1.11 mycroft exit (1);
363 1.1 cgd }
364 1.1 cgd }
365 1.11 mycroft
366 1.11 mycroft /* If we are serving udp, set up the socket. */
367 1.1 cgd if (udpflag) {
368 1.32 fvdl if ((sock = socket(ai_udp->ai_family, ai_udp->ai_socktype,
369 1.32 fvdl ai_udp->ai_protocol)) < 0) {
370 1.11 mycroft syslog(LOG_ERR, "can't create udp socket");
371 1.1 cgd exit(1);
372 1.1 cgd }
373 1.32 fvdl if (bind(sock, ai_udp->ai_addr, ai_udp->ai_addrlen) < 0) {
374 1.32 fvdl syslog(LOG_ERR, "can't bind udp addr");
375 1.32 fvdl exit(1);
376 1.32 fvdl }
377 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp, &nb_udp) ||
378 1.32 fvdl !rpcb_set(RPCPROG_NFS, 3, nconf_udp, &nb_udp)) {
379 1.32 fvdl syslog(LOG_ERR, "can't register with udp portmap");
380 1.32 fvdl exit(1);
381 1.32 fvdl }
382 1.32 fvdl nfsdargs.sock = sock;
383 1.32 fvdl nfsdargs.name = NULL;
384 1.32 fvdl nfsdargs.namelen = 0;
385 1.32 fvdl if (nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
386 1.32 fvdl syslog(LOG_ERR, "can't add UDP socket");
387 1.32 fvdl exit(1);
388 1.32 fvdl }
389 1.32 fvdl (void)close(sock);
390 1.32 fvdl }
391 1.32 fvdl
392 1.32 fvdl if (udpflag &&ip6flag) {
393 1.32 fvdl if ((sock = socket(ai_udp6->ai_family, ai_udp6->ai_socktype,
394 1.32 fvdl ai_udp6->ai_protocol)) < 0) {
395 1.32 fvdl syslog(LOG_ERR, "can't create udp socket");
396 1.32 fvdl exit(1);
397 1.32 fvdl }
398 1.36 itojun if (setsockopt(sock, IPPROTO_IPV6, IPV6_V6ONLY,
399 1.32 fvdl &on, sizeof on) < 0) {
400 1.32 fvdl syslog(LOG_ERR, "can't set v6-only binding for udp6 "
401 1.32 fvdl "socket: %m");
402 1.32 fvdl exit(1);
403 1.32 fvdl }
404 1.32 fvdl if (bind(sock, ai_udp6->ai_addr, ai_udp6->ai_addrlen) < 0) {
405 1.11 mycroft syslog(LOG_ERR, "can't bind udp addr");
406 1.1 cgd exit(1);
407 1.1 cgd }
408 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp6, &nb_udp6) ||
409 1.32 fvdl !rpcb_set(RPCPROG_NFS, 3, nconf_udp6, &nb_udp6)) {
410 1.11 mycroft syslog(LOG_ERR, "can't register with udp portmap");
411 1.11 mycroft exit(1);
412 1.11 mycroft }
413 1.11 mycroft nfsdargs.sock = sock;
414 1.11 mycroft nfsdargs.name = NULL;
415 1.11 mycroft nfsdargs.namelen = 0;
416 1.11 mycroft if (nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
417 1.32 fvdl syslog(LOG_ERR, "can't add UDP6 socket");
418 1.11 mycroft exit(1);
419 1.11 mycroft }
420 1.11 mycroft (void)close(sock);
421 1.11 mycroft }
422 1.11 mycroft
423 1.11 mycroft #ifdef ISO
424 1.11 mycroft /* If we are serving cltp, set up the socket. */
425 1.11 mycroft if (cltpflag) {
426 1.11 mycroft if ((sock = socket(AF_ISO, SOCK_DGRAM, 0)) < 0) {
427 1.11 mycroft syslog(LOG_ERR, "can't create cltp socket");
428 1.11 mycroft exit(1);
429 1.11 mycroft }
430 1.11 mycroft memset(&isoaddr, 0, sizeof(isoaddr));
431 1.11 mycroft isoaddr.siso_family = AF_ISO;
432 1.11 mycroft isoaddr.siso_tlen = 2;
433 1.11 mycroft cp = TSEL(&isoaddr);
434 1.11 mycroft *cp++ = (NFS_PORT >> 8);
435 1.11 mycroft *cp = (NFS_PORT & 0xff);
436 1.11 mycroft isoaddr.siso_len = sizeof(isoaddr);
437 1.11 mycroft if (bind(sock,
438 1.11 mycroft (struct sockaddr *)&isoaddr, sizeof(isoaddr)) < 0) {
439 1.11 mycroft syslog(LOG_ERR, "can't bind cltp addr");
440 1.1 cgd exit(1);
441 1.1 cgd }
442 1.11 mycroft #ifdef notyet
443 1.1 cgd /*
444 1.11 mycroft * XXX
445 1.11 mycroft * Someday this should probably use "rpcbind", the son of
446 1.11 mycroft * portmap.
447 1.1 cgd */
448 1.11 mycroft if (!pmap_set(RPCPROG_NFS, NFS_VER2, IPPROTO_UDP, NFS_PORT)) {
449 1.11 mycroft syslog(LOG_ERR, "can't register with udp portmap");
450 1.11 mycroft exit(1);
451 1.11 mycroft }
452 1.11 mycroft #endif /* notyet */
453 1.11 mycroft nfsdargs.sock = sock;
454 1.11 mycroft nfsdargs.name = NULL;
455 1.11 mycroft nfsdargs.namelen = 0;
456 1.11 mycroft if (nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
457 1.11 mycroft syslog(LOG_ERR, "can't add UDP socket");
458 1.11 mycroft exit(1);
459 1.11 mycroft }
460 1.1 cgd close(sock);
461 1.1 cgd }
462 1.11 mycroft #endif /* ISO */
463 1.1 cgd
464 1.11 mycroft /* Now set up the master server socket waiting for tcp connections. */
465 1.11 mycroft on = 1;
466 1.11 mycroft connect_type_cnt = 0;
467 1.1 cgd if (tcpflag) {
468 1.32 fvdl if ((tcpsock = socket(ai_tcp->ai_family, ai_tcp->ai_socktype,
469 1.32 fvdl ai_tcp->ai_protocol)) < 0) {
470 1.11 mycroft syslog(LOG_ERR, "can't create tcp socket");
471 1.11 mycroft exit(1);
472 1.11 mycroft }
473 1.11 mycroft if (setsockopt(tcpsock,
474 1.11 mycroft SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
475 1.11 mycroft syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
476 1.32 fvdl if (bind(tcpsock, ai_tcp->ai_addr, ai_tcp->ai_addrlen) < 0) {
477 1.11 mycroft syslog(LOG_ERR, "can't bind tcp addr");
478 1.11 mycroft exit(1);
479 1.11 mycroft }
480 1.11 mycroft if (listen(tcpsock, 5) < 0) {
481 1.11 mycroft syslog(LOG_ERR, "listen failed");
482 1.11 mycroft exit(1);
483 1.11 mycroft }
484 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp, &nb_tcp) ||
485 1.32 fvdl !rpcb_set(RPCPROG_NFS, 3, nconf_tcp, &nb_tcp)) {
486 1.32 fvdl syslog(LOG_ERR, "can't register tcp with rpcbind");
487 1.11 mycroft exit(1);
488 1.11 mycroft }
489 1.37 mycroft set[0].fd = tcpsock;
490 1.37 mycroft set[0].events = POLLIN;
491 1.11 mycroft connect_type_cnt++;
492 1.37 mycroft } else
493 1.38 mycroft set[0].fd = -1;
494 1.1 cgd
495 1.32 fvdl if (tcpflag && ip6flag) {
496 1.32 fvdl if ((tcp6sock = socket(ai_tcp6->ai_family, ai_tcp6->ai_socktype,
497 1.32 fvdl ai_tcp6->ai_protocol)) < 0) {
498 1.32 fvdl syslog(LOG_ERR, "can't create tcp socket");
499 1.32 fvdl exit(1);
500 1.32 fvdl }
501 1.32 fvdl if (setsockopt(tcp6sock,
502 1.32 fvdl SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
503 1.32 fvdl syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
504 1.36 itojun if (setsockopt(tcp6sock, IPPROTO_IPV6, IPV6_V6ONLY,
505 1.32 fvdl &on, sizeof on) < 0) {
506 1.32 fvdl syslog(LOG_ERR, "can't set v6-only binding for tcp6 "
507 1.32 fvdl "socket: %m");
508 1.32 fvdl exit(1);
509 1.32 fvdl }
510 1.32 fvdl if (bind(tcp6sock, ai_tcp6->ai_addr, ai_tcp6->ai_addrlen) < 0) {
511 1.32 fvdl syslog(LOG_ERR, "can't bind tcp6 addr");
512 1.32 fvdl exit(1);
513 1.32 fvdl }
514 1.32 fvdl if (listen(tcp6sock, 5) < 0) {
515 1.32 fvdl syslog(LOG_ERR, "listen failed");
516 1.32 fvdl exit(1);
517 1.32 fvdl }
518 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp6, &nb_tcp6) ||
519 1.32 fvdl !rpcb_set(RPCPROG_NFS, 3, nconf_tcp6, &nb_tcp6)) {
520 1.32 fvdl syslog(LOG_ERR, "can't register tcp6 with rpcbind");
521 1.32 fvdl exit(1);
522 1.32 fvdl }
523 1.37 mycroft set[1].fd = tcp6sock;
524 1.37 mycroft set[1].events = POLLIN;
525 1.32 fvdl connect_type_cnt++;
526 1.37 mycroft } else
527 1.38 mycroft set[1].fd = -1;
528 1.32 fvdl
529 1.11 mycroft #ifdef notyet
530 1.11 mycroft /* Now set up the master server socket waiting for tp4 connections. */
531 1.11 mycroft if (tp4flag) {
532 1.11 mycroft if ((tp4sock = socket(AF_ISO, SOCK_SEQPACKET, 0)) < 0) {
533 1.11 mycroft syslog(LOG_ERR, "can't create tp4 socket");
534 1.1 cgd exit(1);
535 1.1 cgd }
536 1.11 mycroft if (setsockopt(tp4sock,
537 1.11 mycroft SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
538 1.1 cgd syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
539 1.11 mycroft memset(&isoaddr, 0, sizeof(isoaddr));
540 1.11 mycroft isoaddr.siso_family = AF_ISO;
541 1.11 mycroft isoaddr.siso_tlen = 2;
542 1.11 mycroft cp = TSEL(&isoaddr);
543 1.11 mycroft *cp++ = (NFS_PORT >> 8);
544 1.11 mycroft *cp = (NFS_PORT & 0xff);
545 1.11 mycroft isoaddr.siso_len = sizeof(isoaddr);
546 1.11 mycroft if (bind(tp4sock,
547 1.12 mycroft (struct sockaddr *)&isoaddr, sizeof(isoaddr)) < 0) {
548 1.11 mycroft syslog(LOG_ERR, "can't bind tp4 addr");
549 1.1 cgd exit(1);
550 1.1 cgd }
551 1.11 mycroft if (listen(tp4sock, 5) < 0) {
552 1.11 mycroft syslog(LOG_ERR, "listen failed");
553 1.1 cgd exit(1);
554 1.1 cgd }
555 1.11 mycroft /*
556 1.11 mycroft * XXX
557 1.11 mycroft * Someday this should probably use "rpcbind", the son of
558 1.11 mycroft * portmap.
559 1.11 mycroft */
560 1.1 cgd if (!pmap_set(RPCPROG_NFS, NFS_VER2, IPPROTO_TCP, NFS_PORT)) {
561 1.11 mycroft syslog(LOG_ERR, "can't register tcp with portmap");
562 1.11 mycroft exit(1);
563 1.11 mycroft }
564 1.37 mycroft set[2].fd = tp4sock;
565 1.37 mycroft set[2].events = POLLIN;
566 1.11 mycroft connect_type_cnt++;
567 1.37 mycroft } else
568 1.38 mycroft set[2].fd = -1;
569 1.11 mycroft
570 1.11 mycroft /* Now set up the master server socket waiting for tpip connections. */
571 1.11 mycroft if (tpipflag) {
572 1.11 mycroft if ((tpipsock = socket(AF_INET, SOCK_SEQPACKET, 0)) < 0) {
573 1.11 mycroft syslog(LOG_ERR, "can't create tpip socket");
574 1.11 mycroft exit(1);
575 1.11 mycroft }
576 1.11 mycroft if (setsockopt(tpipsock,
577 1.11 mycroft SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
578 1.11 mycroft syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
579 1.11 mycroft inetaddr.sin_family = AF_INET;
580 1.11 mycroft inetaddr.sin_addr.s_addr = INADDR_ANY;
581 1.11 mycroft inetaddr.sin_port = htons(NFS_PORT);
582 1.11 mycroft inetaddr.sin_len = sizeof(inetaddr);
583 1.20 mycroft memset(inetaddr.sin_zero, 0, sizeof(inetaddr.sin_zero));
584 1.11 mycroft if (bind(tpipsock,
585 1.11 mycroft (struct sockaddr *)&inetaddr, sizeof (inetaddr)) < 0) {
586 1.11 mycroft syslog(LOG_ERR, "can't bind tcp addr");
587 1.11 mycroft exit(1);
588 1.11 mycroft }
589 1.11 mycroft if (listen(tpipsock, 5) < 0) {
590 1.11 mycroft syslog(LOG_ERR, "listen failed");
591 1.1 cgd exit(1);
592 1.1 cgd }
593 1.1 cgd /*
594 1.11 mycroft * XXX
595 1.11 mycroft * Someday this should probably use "rpcbind", the son of
596 1.11 mycroft * portmap.
597 1.1 cgd */
598 1.11 mycroft if (!pmap_set(RPCPROG_NFS, NFS_VER2, IPPROTO_TCP, NFS_PORT)) {
599 1.11 mycroft syslog(LOG_ERR, "can't register tcp with portmap");
600 1.11 mycroft exit(1);
601 1.11 mycroft }
602 1.37 mycroft set[3].fd = tpipsock;
603 1.37 mycroft set[3].events = POLLIN;
604 1.11 mycroft connect_type_cnt++;
605 1.37 mycroft } else
606 1.38 mycroft set[3].fd = -1;
607 1.37 mycroft #else
608 1.38 mycroft set[2].fd = -1;
609 1.38 mycroft set[3].fd = -1;
610 1.11 mycroft #endif /* notyet */
611 1.11 mycroft
612 1.11 mycroft if (connect_type_cnt == 0)
613 1.11 mycroft exit(0);
614 1.11 mycroft
615 1.51 yamt pthread_setname_np(pthread_self(), "master", NULL);
616 1.11 mycroft
617 1.11 mycroft /*
618 1.11 mycroft * Loop forever accepting connections and passing the sockets
619 1.11 mycroft * into the kernel for the mounts.
620 1.11 mycroft */
621 1.11 mycroft for (;;) {
622 1.41 mycroft if (poll(set, 4, INFTIM) < 1) {
623 1.49 elad syslog(LOG_ERR, "poll failed: %m");
624 1.41 mycroft exit(1);
625 1.11 mycroft }
626 1.38 mycroft
627 1.37 mycroft if (set[0].revents & POLLIN) {
628 1.11 mycroft len = sizeof(inetpeer);
629 1.11 mycroft if ((msgsock = accept(tcpsock,
630 1.11 mycroft (struct sockaddr *)&inetpeer, &len)) < 0) {
631 1.11 mycroft syslog(LOG_ERR, "accept failed: %m");
632 1.1 cgd exit(1);
633 1.1 cgd }
634 1.11 mycroft memset(inetpeer.sin_zero, 0, sizeof(inetpeer.sin_zero));
635 1.11 mycroft if (setsockopt(msgsock, SOL_SOCKET,
636 1.11 mycroft SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
637 1.11 mycroft syslog(LOG_ERR,
638 1.11 mycroft "setsockopt SO_KEEPALIVE: %m");
639 1.11 mycroft nfsdargs.sock = msgsock;
640 1.11 mycroft nfsdargs.name = (caddr_t)&inetpeer;
641 1.11 mycroft nfsdargs.namelen = sizeof(inetpeer);
642 1.11 mycroft nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
643 1.11 mycroft (void)close(msgsock);
644 1.11 mycroft }
645 1.32 fvdl
646 1.37 mycroft if (set[1].revents & POLLIN) {
647 1.32 fvdl len = sizeof(inet6peer);
648 1.32 fvdl if ((msgsock = accept(tcp6sock,
649 1.32 fvdl (struct sockaddr *)&inet6peer, &len)) < 0) {
650 1.32 fvdl syslog(LOG_ERR, "accept failed: %m");
651 1.32 fvdl exit(1);
652 1.32 fvdl }
653 1.32 fvdl if (setsockopt(msgsock, SOL_SOCKET,
654 1.32 fvdl SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
655 1.32 fvdl syslog(LOG_ERR,
656 1.32 fvdl "setsockopt SO_KEEPALIVE: %m");
657 1.32 fvdl nfsdargs.sock = msgsock;
658 1.32 fvdl nfsdargs.name = (caddr_t)&inet6peer;
659 1.32 fvdl nfsdargs.namelen = sizeof(inet6peer);
660 1.32 fvdl nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
661 1.32 fvdl (void)close(msgsock);
662 1.32 fvdl }
663 1.32 fvdl
664 1.11 mycroft #ifdef notyet
665 1.37 mycroft if (set[2].revents & POLLIN) {
666 1.11 mycroft len = sizeof(isopeer);
667 1.11 mycroft if ((msgsock = accept(tp4sock,
668 1.11 mycroft (struct sockaddr *)&isopeer, &len)) < 0) {
669 1.11 mycroft syslog(LOG_ERR, "accept failed: %m");
670 1.11 mycroft exit(1);
671 1.1 cgd }
672 1.11 mycroft if (setsockopt(msgsock, SOL_SOCKET,
673 1.11 mycroft SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
674 1.11 mycroft syslog(LOG_ERR,
675 1.11 mycroft "setsockopt SO_KEEPALIVE: %m");
676 1.11 mycroft nfsdargs.sock = msgsock;
677 1.11 mycroft nfsdargs.name = (caddr_t)&isopeer;
678 1.11 mycroft nfsdargs.namelen = len;
679 1.11 mycroft nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
680 1.11 mycroft (void)close(msgsock);
681 1.11 mycroft }
682 1.38 mycroft
683 1.37 mycroft if (set[3].revents & POLLIN) {
684 1.11 mycroft len = sizeof(inetpeer);
685 1.11 mycroft if ((msgsock = accept(tpipsock,
686 1.11 mycroft (struct sockaddr *)&inetpeer, &len)) < 0) {
687 1.41 mycroft syslog(LOG_ERR, "accept failed: %m");
688 1.1 cgd exit(1);
689 1.1 cgd }
690 1.11 mycroft if (setsockopt(msgsock, SOL_SOCKET,
691 1.11 mycroft SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
692 1.11 mycroft syslog(LOG_ERR, "setsockopt SO_KEEPALIVE: %m");
693 1.11 mycroft nfsdargs.sock = msgsock;
694 1.11 mycroft nfsdargs.name = (caddr_t)&inetpeer;
695 1.11 mycroft nfsdargs.namelen = len;
696 1.11 mycroft nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
697 1.11 mycroft (void)close(msgsock);
698 1.1 cgd }
699 1.11 mycroft #endif /* notyet */
700 1.1 cgd }
701 1.1 cgd }
702 1.1 cgd
703 1.11 mycroft void
704 1.1 cgd usage()
705 1.1 cgd {
706 1.15 mycroft (void)fprintf(stderr, "usage: nfsd %s\n", USAGE);
707 1.1 cgd exit(1);
708 1.1 cgd }
709 1.1 cgd
710 1.1 cgd void
711 1.11 mycroft nonfs(signo)
712 1.11 mycroft int signo;
713 1.1 cgd {
714 1.11 mycroft syslog(LOG_ERR, "missing system call: NFS not available.");
715 1.1 cgd }
716