nfsd.c revision 1.49 1 1.49 elad /* $NetBSD: nfsd.c,v 1.49 2006/10/07 17:27:57 elad 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.49 elad __RCSID("$NetBSD: nfsd.c,v 1.49 2006/10/07 17:27:57 elad 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.11 mycroft #include <signal.h>
77 1.11 mycroft #include <stdio.h>
78 1.11 mycroft #include <stdlib.h>
79 1.25 perry #include <string.h>
80 1.19 mycroft #include <syslog.h>
81 1.11 mycroft #include <unistd.h>
82 1.32 fvdl #include <netdb.h>
83 1.1 cgd
84 1.1 cgd /* Global defs */
85 1.1 cgd #ifdef DEBUG
86 1.1 cgd #define syslog(e, s) fprintf(stderr,(s))
87 1.1 cgd int debug = 1;
88 1.1 cgd #else
89 1.1 cgd int debug = 0;
90 1.1 cgd #endif
91 1.11 mycroft
92 1.11 mycroft struct nfsd_srvargs nsd;
93 1.11 mycroft
94 1.23 lukem int main __P((int, char **));
95 1.11 mycroft void nonfs __P((int));
96 1.11 mycroft void reapchild __P((int));
97 1.11 mycroft void usage __P((void));
98 1.1 cgd
99 1.1 cgd /*
100 1.1 cgd * Nfs server daemon mostly just a user context for nfssvc()
101 1.11 mycroft *
102 1.1 cgd * 1 - do file descriptor and signal cleanup
103 1.11 mycroft * 2 - fork the nfsd(s)
104 1.11 mycroft * 3 - create server socket(s)
105 1.11 mycroft * 4 - register socket with portmap
106 1.11 mycroft *
107 1.28 lukem * For connectionless protocols, just pass the socket into the kernel via
108 1.11 mycroft * nfssvc().
109 1.11 mycroft * For connection based sockets, loop doing accepts. When you get a new
110 1.28 lukem * socket from accept, pass the msgsock into the kernel via nfssvc().
111 1.1 cgd * The arguments are:
112 1.11 mycroft * -c - support iso cltp clients
113 1.11 mycroft * -r - reregister with portmapper
114 1.11 mycroft * -t - support tcp nfs clients
115 1.11 mycroft * -u - support udp nfs clients
116 1.11 mycroft * followed by "n" which is the number of nfsds' to fork off
117 1.1 cgd */
118 1.11 mycroft int
119 1.23 lukem main(argc, argv)
120 1.1 cgd int argc;
121 1.23 lukem char *argv[];
122 1.1 cgd {
123 1.11 mycroft struct nfsd_args nfsdargs;
124 1.32 fvdl struct addrinfo *ai_udp, *ai_tcp, *ai_udp6, *ai_tcp6, hints;
125 1.32 fvdl struct netconfig *nconf_udp, *nconf_tcp, *nconf_udp6, *nconf_tcp6;
126 1.32 fvdl struct netbuf nb_udp, nb_tcp, nb_udp6, nb_tcp6;
127 1.32 fvdl struct sockaddr_in inetpeer;
128 1.32 fvdl struct sockaddr_in6 inet6peer;
129 1.11 mycroft #ifdef ISO
130 1.11 mycroft struct sockaddr_iso isoaddr, isopeer;
131 1.11 mycroft #endif
132 1.37 mycroft struct pollfd set[4];
133 1.47 mrg socklen_t len;
134 1.47 mrg int ch, cltpflag, connect_type_cnt, i, maxsock, msgsock;
135 1.32 fvdl int nfsdcnt, nfssvc_flag, on = 1, reregister, sock, tcpflag, tcpsock;
136 1.32 fvdl int tcp6sock, ip6flag;
137 1.32 fvdl int tp4cnt, tp4flag, tpipcnt, tpipflag, udpflag, ecode, s;
138 1.11 mycroft
139 1.44 jonathan #define MAXNFSDCNT 1024
140 1.11 mycroft #define DEFNFSDCNT 4
141 1.11 mycroft nfsdcnt = DEFNFSDCNT;
142 1.11 mycroft cltpflag = reregister = tcpflag = tp4cnt = tp4flag = tpipcnt = 0;
143 1.32 fvdl tpipflag = udpflag = ip6flag = 0;
144 1.45 lukem nconf_udp = nconf_tcp = nconf_udp6 = nconf_tcp6 = NULL;
145 1.45 lukem maxsock = 0;
146 1.45 lukem tcpsock = tcp6sock = -1;
147 1.11 mycroft #ifdef ISO
148 1.32 fvdl #define GETOPT "6cn:rtu"
149 1.11 mycroft #define USAGE "[-crtu] [-n num_servers]"
150 1.11 mycroft #else
151 1.32 fvdl #define GETOPT "6n:rtu"
152 1.11 mycroft #define USAGE "[-rtu] [-n num_servers]"
153 1.11 mycroft #endif
154 1.30 thorpej while ((ch = getopt(argc, argv, GETOPT)) != -1) {
155 1.11 mycroft switch (ch) {
156 1.32 fvdl case '6':
157 1.32 fvdl ip6flag = 1;
158 1.32 fvdl s = socket(PF_INET6, SOCK_DGRAM, IPPROTO_UDP);
159 1.32 fvdl if (s < 0 && (errno == EPROTONOSUPPORT ||
160 1.32 fvdl errno == EPFNOSUPPORT || errno == EAFNOSUPPORT))
161 1.32 fvdl ip6flag = 0;
162 1.32 fvdl else
163 1.32 fvdl close(s);
164 1.32 fvdl break;
165 1.11 mycroft case 'n':
166 1.11 mycroft nfsdcnt = atoi(optarg);
167 1.11 mycroft if (nfsdcnt < 1 || nfsdcnt > MAXNFSDCNT) {
168 1.21 fvdl warnx("nfsd count %d; reset to %d", nfsdcnt, DEFNFSDCNT);
169 1.11 mycroft nfsdcnt = DEFNFSDCNT;
170 1.11 mycroft }
171 1.11 mycroft break;
172 1.1 cgd case 'r':
173 1.11 mycroft reregister = 1;
174 1.1 cgd break;
175 1.1 cgd case 't':
176 1.11 mycroft tcpflag = 1;
177 1.1 cgd break;
178 1.1 cgd case 'u':
179 1.11 mycroft udpflag = 1;
180 1.11 mycroft break;
181 1.11 mycroft #ifdef ISO
182 1.11 mycroft case 'c':
183 1.11 mycroft cltpflag = 1;
184 1.1 cgd break;
185 1.11 mycroft #ifdef notyet
186 1.11 mycroft case 'i':
187 1.11 mycroft tp4cnt = 1;
188 1.11 mycroft break;
189 1.11 mycroft case 'p':
190 1.11 mycroft tpipcnt = 1;
191 1.11 mycroft break;
192 1.11 mycroft #endif /* notyet */
193 1.11 mycroft #endif /* ISO */
194 1.1 cgd default:
195 1.1 cgd case '?':
196 1.1 cgd usage();
197 1.11 mycroft };
198 1.30 thorpej }
199 1.11 mycroft argv += optind;
200 1.11 mycroft argc -= optind;
201 1.1 cgd
202 1.1 cgd /*
203 1.11 mycroft * XXX
204 1.11 mycroft * Backward compatibility, trailing number is the count of daemons.
205 1.1 cgd */
206 1.11 mycroft if (argc > 1)
207 1.11 mycroft usage();
208 1.11 mycroft if (argc == 1) {
209 1.11 mycroft nfsdcnt = atoi(argv[0]);
210 1.11 mycroft if (nfsdcnt < 1 || nfsdcnt > MAXNFSDCNT) {
211 1.21 fvdl warnx("nfsd count %d; reset to %d", nfsdcnt, DEFNFSDCNT);
212 1.11 mycroft nfsdcnt = DEFNFSDCNT;
213 1.11 mycroft }
214 1.1 cgd }
215 1.31 soren
216 1.31 soren /*
217 1.31 soren * If none of TCP or UDP are specified, default to UDP only.
218 1.31 soren */
219 1.31 soren if (tcpflag == 0 && udpflag == 0)
220 1.31 soren udpflag = 1;
221 1.1 cgd
222 1.1 cgd if (debug == 0) {
223 1.1 cgd daemon(0, 0);
224 1.11 mycroft (void)signal(SIGHUP, SIG_IGN);
225 1.11 mycroft (void)signal(SIGINT, SIG_IGN);
226 1.11 mycroft (void)signal(SIGQUIT, SIG_IGN);
227 1.11 mycroft (void)signal(SIGSYS, nonfs);
228 1.1 cgd }
229 1.11 mycroft (void)signal(SIGCHLD, reapchild);
230 1.11 mycroft
231 1.32 fvdl if (udpflag) {
232 1.32 fvdl memset(&hints, 0, sizeof hints);
233 1.32 fvdl hints.ai_flags = AI_PASSIVE;
234 1.32 fvdl hints.ai_family = PF_INET;
235 1.32 fvdl hints.ai_socktype = SOCK_DGRAM;
236 1.32 fvdl hints.ai_protocol = IPPROTO_UDP;
237 1.32 fvdl
238 1.32 fvdl ecode = getaddrinfo(NULL, "nfs", &hints, &ai_udp);
239 1.32 fvdl if (ecode != 0) {
240 1.32 fvdl syslog(LOG_ERR, "getaddrinfo udp: %s",
241 1.32 fvdl gai_strerror(ecode));
242 1.32 fvdl exit(1);
243 1.32 fvdl }
244 1.32 fvdl
245 1.32 fvdl nconf_udp = getnetconfigent("udp");
246 1.32 fvdl
247 1.32 fvdl if (nconf_udp == NULL)
248 1.32 fvdl err(1, "getnetconfigent udp failed");
249 1.32 fvdl
250 1.32 fvdl nb_udp.buf = ai_udp->ai_addr;
251 1.32 fvdl nb_udp.len = nb_udp.maxlen = ai_udp->ai_addrlen;
252 1.32 fvdl if (reregister)
253 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp, &nb_udp))
254 1.32 fvdl err(1, "rpcb_set udp failed");
255 1.32 fvdl }
256 1.32 fvdl
257 1.32 fvdl if (tcpflag) {
258 1.32 fvdl memset(&hints, 0, sizeof hints);
259 1.32 fvdl hints.ai_flags = AI_PASSIVE;
260 1.32 fvdl hints.ai_family = PF_INET;
261 1.32 fvdl hints.ai_socktype = SOCK_STREAM;
262 1.32 fvdl hints.ai_protocol = IPPROTO_TCP;
263 1.32 fvdl
264 1.32 fvdl ecode = getaddrinfo(NULL, "nfs", &hints, &ai_tcp);
265 1.32 fvdl if (ecode != 0) {
266 1.48 hubertf syslog(LOG_ERR, "getaddrinfo tcp: %s",
267 1.32 fvdl gai_strerror(ecode));
268 1.32 fvdl exit(1);
269 1.32 fvdl }
270 1.32 fvdl
271 1.32 fvdl nconf_tcp = getnetconfigent("tcp");
272 1.32 fvdl
273 1.32 fvdl if (nconf_tcp == NULL)
274 1.32 fvdl err(1, "getnetconfigent tcp failed");
275 1.32 fvdl
276 1.32 fvdl nb_tcp.buf = ai_tcp->ai_addr;
277 1.32 fvdl nb_tcp.len = nb_tcp.maxlen = ai_tcp->ai_addrlen;
278 1.32 fvdl if (reregister)
279 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp, &nb_tcp))
280 1.32 fvdl err(1, "rpcb_set tcp failed");
281 1.32 fvdl }
282 1.32 fvdl
283 1.32 fvdl if (udpflag && ip6flag) {
284 1.32 fvdl memset(&hints, 0, sizeof hints);
285 1.32 fvdl hints.ai_flags = AI_PASSIVE;
286 1.32 fvdl hints.ai_family = PF_INET6;
287 1.32 fvdl hints.ai_socktype = SOCK_DGRAM;
288 1.32 fvdl hints.ai_protocol = IPPROTO_UDP;
289 1.32 fvdl
290 1.32 fvdl ecode = getaddrinfo(NULL, "nfs", &hints, &ai_udp6);
291 1.32 fvdl if (ecode != 0) {
292 1.32 fvdl syslog(LOG_ERR, "getaddrinfo udp: %s",
293 1.32 fvdl gai_strerror(ecode));
294 1.32 fvdl exit(1);
295 1.32 fvdl }
296 1.32 fvdl
297 1.32 fvdl nconf_udp6 = getnetconfigent("udp6");
298 1.32 fvdl
299 1.32 fvdl if (nconf_udp6 == NULL)
300 1.32 fvdl err(1, "getnetconfigent udp6 failed");
301 1.32 fvdl
302 1.32 fvdl nb_udp6.buf = ai_udp6->ai_addr;
303 1.32 fvdl nb_udp6.len = nb_udp6.maxlen = ai_udp6->ai_addrlen;
304 1.32 fvdl if (reregister)
305 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp6, &nb_udp6))
306 1.32 fvdl err(1, "rpcb_set udp6 failed");
307 1.32 fvdl }
308 1.32 fvdl
309 1.32 fvdl if (tcpflag && ip6flag) {
310 1.32 fvdl memset(&hints, 0, sizeof hints);
311 1.32 fvdl hints.ai_flags = AI_PASSIVE;
312 1.32 fvdl hints.ai_family = PF_INET6;
313 1.32 fvdl hints.ai_socktype = SOCK_STREAM;
314 1.32 fvdl hints.ai_protocol = IPPROTO_TCP;
315 1.32 fvdl
316 1.32 fvdl ecode = getaddrinfo(NULL, "nfs", &hints, &ai_tcp6);
317 1.32 fvdl if (ecode != 0) {
318 1.48 hubertf syslog(LOG_ERR, "getaddrinfo tcp: %s",
319 1.32 fvdl gai_strerror(ecode));
320 1.32 fvdl exit(1);
321 1.32 fvdl }
322 1.32 fvdl
323 1.32 fvdl nconf_tcp6 = getnetconfigent("tcp6");
324 1.32 fvdl
325 1.32 fvdl if (nconf_tcp6 == NULL)
326 1.32 fvdl err(1, "getnetconfigent tcp6 failed");
327 1.32 fvdl
328 1.32 fvdl nb_tcp6.buf = ai_tcp6->ai_addr;
329 1.32 fvdl nb_tcp6.len = nb_tcp6.maxlen = ai_tcp6->ai_addrlen;
330 1.32 fvdl if (reregister)
331 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp6, &nb_tcp6))
332 1.32 fvdl err(1, "rpcb_set tcp6 failed");
333 1.8 cgd }
334 1.32 fvdl
335 1.33 lukem openlog("nfsd", LOG_PID, LOG_DAEMON);
336 1.11 mycroft
337 1.11 mycroft for (i = 0; i < nfsdcnt; i++) {
338 1.11 mycroft switch (fork()) {
339 1.11 mycroft case -1:
340 1.11 mycroft syslog(LOG_ERR, "fork: %m");
341 1.11 mycroft exit (1);
342 1.11 mycroft case 0:
343 1.11 mycroft break;
344 1.11 mycroft default:
345 1.11 mycroft continue;
346 1.1 cgd }
347 1.11 mycroft
348 1.13 mycroft setproctitle("server");
349 1.11 mycroft nfssvc_flag = NFSSVC_NFSD;
350 1.11 mycroft nsd.nsd_nfsd = NULL;
351 1.11 mycroft while (nfssvc(nfssvc_flag, &nsd) < 0) {
352 1.11 mycroft if (errno != ENEEDAUTH) {
353 1.11 mycroft syslog(LOG_ERR, "nfssvc: %m");
354 1.11 mycroft exit(1);
355 1.11 mycroft }
356 1.11 mycroft nfssvc_flag = NFSSVC_NFSD | NFSSVC_AUTHINFAIL;
357 1.1 cgd }
358 1.1 cgd exit(0);
359 1.1 cgd }
360 1.11 mycroft
361 1.11 mycroft /* If we are serving udp, set up the socket. */
362 1.1 cgd if (udpflag) {
363 1.32 fvdl if ((sock = socket(ai_udp->ai_family, ai_udp->ai_socktype,
364 1.32 fvdl ai_udp->ai_protocol)) < 0) {
365 1.11 mycroft syslog(LOG_ERR, "can't create udp socket");
366 1.1 cgd exit(1);
367 1.1 cgd }
368 1.32 fvdl if (bind(sock, ai_udp->ai_addr, ai_udp->ai_addrlen) < 0) {
369 1.32 fvdl syslog(LOG_ERR, "can't bind udp addr");
370 1.32 fvdl exit(1);
371 1.32 fvdl }
372 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp, &nb_udp) ||
373 1.32 fvdl !rpcb_set(RPCPROG_NFS, 3, nconf_udp, &nb_udp)) {
374 1.32 fvdl syslog(LOG_ERR, "can't register with udp portmap");
375 1.32 fvdl exit(1);
376 1.32 fvdl }
377 1.32 fvdl nfsdargs.sock = sock;
378 1.32 fvdl nfsdargs.name = NULL;
379 1.32 fvdl nfsdargs.namelen = 0;
380 1.32 fvdl if (nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
381 1.32 fvdl syslog(LOG_ERR, "can't add UDP socket");
382 1.32 fvdl exit(1);
383 1.32 fvdl }
384 1.32 fvdl (void)close(sock);
385 1.32 fvdl }
386 1.32 fvdl
387 1.32 fvdl if (udpflag &&ip6flag) {
388 1.32 fvdl if ((sock = socket(ai_udp6->ai_family, ai_udp6->ai_socktype,
389 1.32 fvdl ai_udp6->ai_protocol)) < 0) {
390 1.32 fvdl syslog(LOG_ERR, "can't create udp socket");
391 1.32 fvdl exit(1);
392 1.32 fvdl }
393 1.36 itojun if (setsockopt(sock, IPPROTO_IPV6, IPV6_V6ONLY,
394 1.32 fvdl &on, sizeof on) < 0) {
395 1.32 fvdl syslog(LOG_ERR, "can't set v6-only binding for udp6 "
396 1.32 fvdl "socket: %m");
397 1.32 fvdl exit(1);
398 1.32 fvdl }
399 1.32 fvdl if (bind(sock, ai_udp6->ai_addr, ai_udp6->ai_addrlen) < 0) {
400 1.11 mycroft syslog(LOG_ERR, "can't bind udp addr");
401 1.1 cgd exit(1);
402 1.1 cgd }
403 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp6, &nb_udp6) ||
404 1.32 fvdl !rpcb_set(RPCPROG_NFS, 3, nconf_udp6, &nb_udp6)) {
405 1.11 mycroft syslog(LOG_ERR, "can't register with udp portmap");
406 1.11 mycroft exit(1);
407 1.11 mycroft }
408 1.11 mycroft nfsdargs.sock = sock;
409 1.11 mycroft nfsdargs.name = NULL;
410 1.11 mycroft nfsdargs.namelen = 0;
411 1.11 mycroft if (nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
412 1.32 fvdl syslog(LOG_ERR, "can't add UDP6 socket");
413 1.11 mycroft exit(1);
414 1.11 mycroft }
415 1.11 mycroft (void)close(sock);
416 1.11 mycroft }
417 1.11 mycroft
418 1.11 mycroft #ifdef ISO
419 1.11 mycroft /* If we are serving cltp, set up the socket. */
420 1.11 mycroft if (cltpflag) {
421 1.11 mycroft if ((sock = socket(AF_ISO, SOCK_DGRAM, 0)) < 0) {
422 1.11 mycroft syslog(LOG_ERR, "can't create cltp socket");
423 1.11 mycroft exit(1);
424 1.11 mycroft }
425 1.11 mycroft memset(&isoaddr, 0, sizeof(isoaddr));
426 1.11 mycroft isoaddr.siso_family = AF_ISO;
427 1.11 mycroft isoaddr.siso_tlen = 2;
428 1.11 mycroft cp = TSEL(&isoaddr);
429 1.11 mycroft *cp++ = (NFS_PORT >> 8);
430 1.11 mycroft *cp = (NFS_PORT & 0xff);
431 1.11 mycroft isoaddr.siso_len = sizeof(isoaddr);
432 1.11 mycroft if (bind(sock,
433 1.11 mycroft (struct sockaddr *)&isoaddr, sizeof(isoaddr)) < 0) {
434 1.11 mycroft syslog(LOG_ERR, "can't bind cltp addr");
435 1.1 cgd exit(1);
436 1.1 cgd }
437 1.11 mycroft #ifdef notyet
438 1.1 cgd /*
439 1.11 mycroft * XXX
440 1.11 mycroft * Someday this should probably use "rpcbind", the son of
441 1.11 mycroft * portmap.
442 1.1 cgd */
443 1.11 mycroft if (!pmap_set(RPCPROG_NFS, NFS_VER2, IPPROTO_UDP, NFS_PORT)) {
444 1.11 mycroft syslog(LOG_ERR, "can't register with udp portmap");
445 1.11 mycroft exit(1);
446 1.11 mycroft }
447 1.11 mycroft #endif /* notyet */
448 1.11 mycroft nfsdargs.sock = sock;
449 1.11 mycroft nfsdargs.name = NULL;
450 1.11 mycroft nfsdargs.namelen = 0;
451 1.11 mycroft if (nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
452 1.11 mycroft syslog(LOG_ERR, "can't add UDP socket");
453 1.11 mycroft exit(1);
454 1.11 mycroft }
455 1.1 cgd close(sock);
456 1.1 cgd }
457 1.11 mycroft #endif /* ISO */
458 1.1 cgd
459 1.11 mycroft /* Now set up the master server socket waiting for tcp connections. */
460 1.11 mycroft on = 1;
461 1.11 mycroft connect_type_cnt = 0;
462 1.1 cgd if (tcpflag) {
463 1.32 fvdl if ((tcpsock = socket(ai_tcp->ai_family, ai_tcp->ai_socktype,
464 1.32 fvdl ai_tcp->ai_protocol)) < 0) {
465 1.11 mycroft syslog(LOG_ERR, "can't create tcp socket");
466 1.11 mycroft exit(1);
467 1.11 mycroft }
468 1.11 mycroft if (setsockopt(tcpsock,
469 1.11 mycroft SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
470 1.11 mycroft syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
471 1.32 fvdl if (bind(tcpsock, ai_tcp->ai_addr, ai_tcp->ai_addrlen) < 0) {
472 1.11 mycroft syslog(LOG_ERR, "can't bind tcp addr");
473 1.11 mycroft exit(1);
474 1.11 mycroft }
475 1.11 mycroft if (listen(tcpsock, 5) < 0) {
476 1.11 mycroft syslog(LOG_ERR, "listen failed");
477 1.11 mycroft exit(1);
478 1.11 mycroft }
479 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp, &nb_tcp) ||
480 1.32 fvdl !rpcb_set(RPCPROG_NFS, 3, nconf_tcp, &nb_tcp)) {
481 1.32 fvdl syslog(LOG_ERR, "can't register tcp with rpcbind");
482 1.11 mycroft exit(1);
483 1.11 mycroft }
484 1.37 mycroft set[0].fd = tcpsock;
485 1.37 mycroft set[0].events = POLLIN;
486 1.11 mycroft connect_type_cnt++;
487 1.37 mycroft } else
488 1.38 mycroft set[0].fd = -1;
489 1.1 cgd
490 1.32 fvdl if (tcpflag && ip6flag) {
491 1.32 fvdl if ((tcp6sock = socket(ai_tcp6->ai_family, ai_tcp6->ai_socktype,
492 1.32 fvdl ai_tcp6->ai_protocol)) < 0) {
493 1.32 fvdl syslog(LOG_ERR, "can't create tcp socket");
494 1.32 fvdl exit(1);
495 1.32 fvdl }
496 1.32 fvdl if (setsockopt(tcp6sock,
497 1.32 fvdl SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
498 1.32 fvdl syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
499 1.36 itojun if (setsockopt(tcp6sock, IPPROTO_IPV6, IPV6_V6ONLY,
500 1.32 fvdl &on, sizeof on) < 0) {
501 1.32 fvdl syslog(LOG_ERR, "can't set v6-only binding for tcp6 "
502 1.32 fvdl "socket: %m");
503 1.32 fvdl exit(1);
504 1.32 fvdl }
505 1.32 fvdl if (bind(tcp6sock, ai_tcp6->ai_addr, ai_tcp6->ai_addrlen) < 0) {
506 1.32 fvdl syslog(LOG_ERR, "can't bind tcp6 addr");
507 1.32 fvdl exit(1);
508 1.32 fvdl }
509 1.32 fvdl if (listen(tcp6sock, 5) < 0) {
510 1.32 fvdl syslog(LOG_ERR, "listen failed");
511 1.32 fvdl exit(1);
512 1.32 fvdl }
513 1.32 fvdl if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp6, &nb_tcp6) ||
514 1.32 fvdl !rpcb_set(RPCPROG_NFS, 3, nconf_tcp6, &nb_tcp6)) {
515 1.32 fvdl syslog(LOG_ERR, "can't register tcp6 with rpcbind");
516 1.32 fvdl exit(1);
517 1.32 fvdl }
518 1.37 mycroft set[1].fd = tcp6sock;
519 1.37 mycroft set[1].events = POLLIN;
520 1.32 fvdl connect_type_cnt++;
521 1.37 mycroft } else
522 1.38 mycroft set[1].fd = -1;
523 1.32 fvdl
524 1.11 mycroft #ifdef notyet
525 1.11 mycroft /* Now set up the master server socket waiting for tp4 connections. */
526 1.11 mycroft if (tp4flag) {
527 1.11 mycroft if ((tp4sock = socket(AF_ISO, SOCK_SEQPACKET, 0)) < 0) {
528 1.11 mycroft syslog(LOG_ERR, "can't create tp4 socket");
529 1.1 cgd exit(1);
530 1.1 cgd }
531 1.11 mycroft if (setsockopt(tp4sock,
532 1.11 mycroft SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
533 1.1 cgd syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
534 1.11 mycroft memset(&isoaddr, 0, sizeof(isoaddr));
535 1.11 mycroft isoaddr.siso_family = AF_ISO;
536 1.11 mycroft isoaddr.siso_tlen = 2;
537 1.11 mycroft cp = TSEL(&isoaddr);
538 1.11 mycroft *cp++ = (NFS_PORT >> 8);
539 1.11 mycroft *cp = (NFS_PORT & 0xff);
540 1.11 mycroft isoaddr.siso_len = sizeof(isoaddr);
541 1.11 mycroft if (bind(tp4sock,
542 1.12 mycroft (struct sockaddr *)&isoaddr, sizeof(isoaddr)) < 0) {
543 1.11 mycroft syslog(LOG_ERR, "can't bind tp4 addr");
544 1.1 cgd exit(1);
545 1.1 cgd }
546 1.11 mycroft if (listen(tp4sock, 5) < 0) {
547 1.11 mycroft syslog(LOG_ERR, "listen failed");
548 1.1 cgd exit(1);
549 1.1 cgd }
550 1.11 mycroft /*
551 1.11 mycroft * XXX
552 1.11 mycroft * Someday this should probably use "rpcbind", the son of
553 1.11 mycroft * portmap.
554 1.11 mycroft */
555 1.1 cgd if (!pmap_set(RPCPROG_NFS, NFS_VER2, IPPROTO_TCP, NFS_PORT)) {
556 1.11 mycroft syslog(LOG_ERR, "can't register tcp with portmap");
557 1.11 mycroft exit(1);
558 1.11 mycroft }
559 1.37 mycroft set[2].fd = tp4sock;
560 1.37 mycroft set[2].events = POLLIN;
561 1.11 mycroft connect_type_cnt++;
562 1.37 mycroft } else
563 1.38 mycroft set[2].fd = -1;
564 1.11 mycroft
565 1.11 mycroft /* Now set up the master server socket waiting for tpip connections. */
566 1.11 mycroft if (tpipflag) {
567 1.11 mycroft if ((tpipsock = socket(AF_INET, SOCK_SEQPACKET, 0)) < 0) {
568 1.11 mycroft syslog(LOG_ERR, "can't create tpip socket");
569 1.11 mycroft exit(1);
570 1.11 mycroft }
571 1.11 mycroft if (setsockopt(tpipsock,
572 1.11 mycroft SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
573 1.11 mycroft syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
574 1.11 mycroft inetaddr.sin_family = AF_INET;
575 1.11 mycroft inetaddr.sin_addr.s_addr = INADDR_ANY;
576 1.11 mycroft inetaddr.sin_port = htons(NFS_PORT);
577 1.11 mycroft inetaddr.sin_len = sizeof(inetaddr);
578 1.20 mycroft memset(inetaddr.sin_zero, 0, sizeof(inetaddr.sin_zero));
579 1.11 mycroft if (bind(tpipsock,
580 1.11 mycroft (struct sockaddr *)&inetaddr, sizeof (inetaddr)) < 0) {
581 1.11 mycroft syslog(LOG_ERR, "can't bind tcp addr");
582 1.11 mycroft exit(1);
583 1.11 mycroft }
584 1.11 mycroft if (listen(tpipsock, 5) < 0) {
585 1.11 mycroft syslog(LOG_ERR, "listen failed");
586 1.1 cgd exit(1);
587 1.1 cgd }
588 1.1 cgd /*
589 1.11 mycroft * XXX
590 1.11 mycroft * Someday this should probably use "rpcbind", the son of
591 1.11 mycroft * portmap.
592 1.1 cgd */
593 1.11 mycroft if (!pmap_set(RPCPROG_NFS, NFS_VER2, IPPROTO_TCP, NFS_PORT)) {
594 1.11 mycroft syslog(LOG_ERR, "can't register tcp with portmap");
595 1.11 mycroft exit(1);
596 1.11 mycroft }
597 1.37 mycroft set[3].fd = tpipsock;
598 1.37 mycroft set[3].events = POLLIN;
599 1.11 mycroft connect_type_cnt++;
600 1.37 mycroft } else
601 1.38 mycroft set[3].fd = -1;
602 1.37 mycroft #else
603 1.38 mycroft set[2].fd = -1;
604 1.38 mycroft set[3].fd = -1;
605 1.11 mycroft #endif /* notyet */
606 1.11 mycroft
607 1.11 mycroft if (connect_type_cnt == 0)
608 1.11 mycroft exit(0);
609 1.11 mycroft
610 1.13 mycroft setproctitle("master");
611 1.11 mycroft
612 1.11 mycroft /*
613 1.11 mycroft * Loop forever accepting connections and passing the sockets
614 1.11 mycroft * into the kernel for the mounts.
615 1.11 mycroft */
616 1.11 mycroft for (;;) {
617 1.41 mycroft if (poll(set, 4, INFTIM) < 1) {
618 1.49 elad syslog(LOG_ERR, "poll failed: %m");
619 1.41 mycroft exit(1);
620 1.11 mycroft }
621 1.38 mycroft
622 1.37 mycroft if (set[0].revents & POLLIN) {
623 1.11 mycroft len = sizeof(inetpeer);
624 1.11 mycroft if ((msgsock = accept(tcpsock,
625 1.11 mycroft (struct sockaddr *)&inetpeer, &len)) < 0) {
626 1.11 mycroft syslog(LOG_ERR, "accept failed: %m");
627 1.1 cgd exit(1);
628 1.1 cgd }
629 1.11 mycroft memset(inetpeer.sin_zero, 0, sizeof(inetpeer.sin_zero));
630 1.11 mycroft if (setsockopt(msgsock, SOL_SOCKET,
631 1.11 mycroft SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
632 1.11 mycroft syslog(LOG_ERR,
633 1.11 mycroft "setsockopt SO_KEEPALIVE: %m");
634 1.11 mycroft nfsdargs.sock = msgsock;
635 1.11 mycroft nfsdargs.name = (caddr_t)&inetpeer;
636 1.11 mycroft nfsdargs.namelen = sizeof(inetpeer);
637 1.11 mycroft nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
638 1.11 mycroft (void)close(msgsock);
639 1.11 mycroft }
640 1.32 fvdl
641 1.37 mycroft if (set[1].revents & POLLIN) {
642 1.32 fvdl len = sizeof(inet6peer);
643 1.32 fvdl if ((msgsock = accept(tcp6sock,
644 1.32 fvdl (struct sockaddr *)&inet6peer, &len)) < 0) {
645 1.32 fvdl syslog(LOG_ERR, "accept failed: %m");
646 1.32 fvdl exit(1);
647 1.32 fvdl }
648 1.32 fvdl if (setsockopt(msgsock, SOL_SOCKET,
649 1.32 fvdl SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
650 1.32 fvdl syslog(LOG_ERR,
651 1.32 fvdl "setsockopt SO_KEEPALIVE: %m");
652 1.32 fvdl nfsdargs.sock = msgsock;
653 1.32 fvdl nfsdargs.name = (caddr_t)&inet6peer;
654 1.32 fvdl nfsdargs.namelen = sizeof(inet6peer);
655 1.32 fvdl nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
656 1.32 fvdl (void)close(msgsock);
657 1.32 fvdl }
658 1.32 fvdl
659 1.11 mycroft #ifdef notyet
660 1.37 mycroft if (set[2].revents & POLLIN) {
661 1.11 mycroft len = sizeof(isopeer);
662 1.11 mycroft if ((msgsock = accept(tp4sock,
663 1.11 mycroft (struct sockaddr *)&isopeer, &len)) < 0) {
664 1.11 mycroft syslog(LOG_ERR, "accept failed: %m");
665 1.11 mycroft exit(1);
666 1.1 cgd }
667 1.11 mycroft if (setsockopt(msgsock, SOL_SOCKET,
668 1.11 mycroft SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
669 1.11 mycroft syslog(LOG_ERR,
670 1.11 mycroft "setsockopt SO_KEEPALIVE: %m");
671 1.11 mycroft nfsdargs.sock = msgsock;
672 1.11 mycroft nfsdargs.name = (caddr_t)&isopeer;
673 1.11 mycroft nfsdargs.namelen = len;
674 1.11 mycroft nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
675 1.11 mycroft (void)close(msgsock);
676 1.11 mycroft }
677 1.38 mycroft
678 1.37 mycroft if (set[3].revents & POLLIN) {
679 1.11 mycroft len = sizeof(inetpeer);
680 1.11 mycroft if ((msgsock = accept(tpipsock,
681 1.11 mycroft (struct sockaddr *)&inetpeer, &len)) < 0) {
682 1.41 mycroft syslog(LOG_ERR, "accept failed: %m");
683 1.1 cgd exit(1);
684 1.1 cgd }
685 1.11 mycroft if (setsockopt(msgsock, SOL_SOCKET,
686 1.11 mycroft SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
687 1.11 mycroft syslog(LOG_ERR, "setsockopt SO_KEEPALIVE: %m");
688 1.11 mycroft nfsdargs.sock = msgsock;
689 1.11 mycroft nfsdargs.name = (caddr_t)&inetpeer;
690 1.11 mycroft nfsdargs.namelen = len;
691 1.11 mycroft nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
692 1.11 mycroft (void)close(msgsock);
693 1.1 cgd }
694 1.11 mycroft #endif /* notyet */
695 1.1 cgd }
696 1.1 cgd }
697 1.1 cgd
698 1.11 mycroft void
699 1.1 cgd usage()
700 1.1 cgd {
701 1.15 mycroft (void)fprintf(stderr, "usage: nfsd %s\n", USAGE);
702 1.1 cgd exit(1);
703 1.1 cgd }
704 1.1 cgd
705 1.1 cgd void
706 1.11 mycroft nonfs(signo)
707 1.11 mycroft int signo;
708 1.1 cgd {
709 1.11 mycroft syslog(LOG_ERR, "missing system call: NFS not available.");
710 1.1 cgd }
711 1.4 glass
712 1.11 mycroft void
713 1.11 mycroft reapchild(signo)
714 1.11 mycroft int signo;
715 1.4 glass {
716 1.18 fvdl while (wait3(NULL, WNOHANG, NULL) > 0);
717 1.4 glass }
718