nfs_syscalls.c revision 1.33 1 1.33 mycroft /* $NetBSD: nfs_syscalls.c,v 1.33 1998/11/08 15:57:44 mycroft Exp $ */
2 1.11 cgd
3 1.1 cgd /*
4 1.10 mycroft * Copyright (c) 1989, 1993
5 1.10 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.1 cgd * 3. All advertising materials mentioning features or use of this software
19 1.1 cgd * must display the following acknowledgement:
20 1.1 cgd * This product includes software developed by the University of
21 1.1 cgd * California, Berkeley and its contributors.
22 1.1 cgd * 4. Neither the name of the University nor the names of its contributors
23 1.1 cgd * may be used to endorse or promote products derived from this software
24 1.1 cgd * without specific prior written permission.
25 1.1 cgd *
26 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
27 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
28 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
29 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
30 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
31 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
32 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
33 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
34 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
35 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
36 1.1 cgd * SUCH DAMAGE.
37 1.1 cgd *
38 1.19 fvdl * @(#)nfs_syscalls.c 8.5 (Berkeley) 3/30/95
39 1.1 cgd */
40 1.28 thorpej
41 1.28 thorpej #include "fs_nfs.h"
42 1.30 thorpej #include "opt_nfsserver.h"
43 1.31 jonathan #include "opt_iso.h"
44 1.1 cgd
45 1.7 mycroft #include <sys/param.h>
46 1.7 mycroft #include <sys/systm.h>
47 1.7 mycroft #include <sys/kernel.h>
48 1.7 mycroft #include <sys/file.h>
49 1.7 mycroft #include <sys/stat.h>
50 1.7 mycroft #include <sys/vnode.h>
51 1.7 mycroft #include <sys/mount.h>
52 1.7 mycroft #include <sys/proc.h>
53 1.10 mycroft #include <sys/uio.h>
54 1.7 mycroft #include <sys/malloc.h>
55 1.7 mycroft #include <sys/buf.h>
56 1.7 mycroft #include <sys/mbuf.h>
57 1.7 mycroft #include <sys/socket.h>
58 1.7 mycroft #include <sys/socketvar.h>
59 1.7 mycroft #include <sys/domain.h>
60 1.7 mycroft #include <sys/protosw.h>
61 1.10 mycroft #include <sys/namei.h>
62 1.10 mycroft #include <sys/syslog.h>
63 1.18 christos #include <sys/filedesc.h>
64 1.1 cgd
65 1.13 cgd #include <sys/syscallargs.h>
66 1.13 cgd
67 1.7 mycroft #include <netinet/in.h>
68 1.7 mycroft #include <netinet/tcp.h>
69 1.10 mycroft #ifdef ISO
70 1.10 mycroft #include <netiso/iso.h>
71 1.10 mycroft #endif
72 1.19 fvdl #include <nfs/xdr_subs.h>
73 1.10 mycroft #include <nfs/rpcv2.h>
74 1.19 fvdl #include <nfs/nfsproto.h>
75 1.7 mycroft #include <nfs/nfs.h>
76 1.19 fvdl #include <nfs/nfsm_subs.h>
77 1.7 mycroft #include <nfs/nfsrvcache.h>
78 1.10 mycroft #include <nfs/nfsmount.h>
79 1.10 mycroft #include <nfs/nfsnode.h>
80 1.10 mycroft #include <nfs/nqnfs.h>
81 1.10 mycroft #include <nfs/nfsrtt.h>
82 1.18 christos #include <nfs/nfs_var.h>
83 1.1 cgd
84 1.19 fvdl void nfsrv_zapsock __P((struct nfssvc_sock *));
85 1.19 fvdl
86 1.1 cgd /* Global defs. */
87 1.19 fvdl extern int32_t (*nfsrv3_procs[NFS_NPROCS]) __P((struct nfsrv_descript *,
88 1.19 fvdl struct nfssvc_sock *,
89 1.19 fvdl struct proc *, struct mbuf **));
90 1.1 cgd extern int nfs_numasync;
91 1.10 mycroft extern time_t nqnfsstarttime;
92 1.10 mycroft extern int nqsrv_writeslack;
93 1.10 mycroft extern int nfsrtton;
94 1.19 fvdl extern struct nfsstats nfsstats;
95 1.19 fvdl extern int nfsrvw_procrastinate;
96 1.10 mycroft struct nfssvc_sock *nfs_udpsock, *nfs_cltpsock;
97 1.10 mycroft int nuidhash_max = NFS_MAXUIDHASH;
98 1.18 christos int nfsd_waiting = 0;
99 1.18 christos #ifdef NFSSERVER
100 1.10 mycroft static int nfs_numnfsd = 0;
101 1.10 mycroft static int notstarted = 1;
102 1.10 mycroft static int modify_flag = 0;
103 1.10 mycroft static struct nfsdrt nfsdrt;
104 1.26 fvdl extern struct nfs_public nfs_pub;
105 1.18 christos #endif
106 1.1 cgd
107 1.1 cgd #define TRUE 1
108 1.1 cgd #define FALSE 0
109 1.1 cgd
110 1.24 thorpej #ifdef NFS
111 1.1 cgd static int nfs_asyncdaemon[NFS_MAXASYNCDAEMON];
112 1.23 thorpej #endif
113 1.19 fvdl
114 1.18 christos #ifdef NFSSERVER
115 1.19 fvdl static void nfsd_rt __P((int, struct nfsrv_descript *, int));
116 1.18 christos #endif
117 1.19 fvdl
118 1.1 cgd /*
119 1.1 cgd * NFS server system calls
120 1.1 cgd * getfh() lives here too, but maybe should move to kern/vfs_syscalls.c
121 1.1 cgd */
122 1.1 cgd
123 1.1 cgd /*
124 1.1 cgd * Get file handle system call
125 1.1 cgd */
126 1.18 christos int
127 1.16 mycroft sys_getfh(p, v, retval)
128 1.1 cgd struct proc *p;
129 1.18 christos register void *v;
130 1.15 thorpej register_t *retval;
131 1.15 thorpej {
132 1.16 mycroft register struct sys_getfh_args /* {
133 1.13 cgd syscallarg(char *) fname;
134 1.13 cgd syscallarg(fhandle_t *) fhp;
135 1.15 thorpej } */ *uap = v;
136 1.1 cgd register struct vnode *vp;
137 1.1 cgd fhandle_t fh;
138 1.1 cgd int error;
139 1.1 cgd struct nameidata nd;
140 1.1 cgd
141 1.1 cgd /*
142 1.1 cgd * Must be super user
143 1.1 cgd */
144 1.19 fvdl error = suser(p->p_ucred, &p->p_acflag);
145 1.25 mycroft if (error)
146 1.1 cgd return (error);
147 1.13 cgd NDINIT(&nd, LOOKUP, FOLLOW | LOCKLEAF, UIO_USERSPACE,
148 1.13 cgd SCARG(uap, fname), p);
149 1.19 fvdl error = namei(&nd);
150 1.19 fvdl if (error)
151 1.1 cgd return (error);
152 1.10 mycroft vp = nd.ni_vp;
153 1.32 perry memset((caddr_t)&fh, 0, sizeof(fh));
154 1.1 cgd fh.fh_fsid = vp->v_mount->mnt_stat.f_fsid;
155 1.1 cgd error = VFS_VPTOFH(vp, &fh.fh_fid);
156 1.1 cgd vput(vp);
157 1.1 cgd if (error)
158 1.1 cgd return (error);
159 1.13 cgd error = copyout((caddr_t)&fh, (caddr_t)SCARG(uap, fhp), sizeof (fh));
160 1.1 cgd return (error);
161 1.1 cgd }
162 1.1 cgd
163 1.1 cgd /*
164 1.19 fvdl * Nfs server pseudo system call for the nfsd's
165 1.10 mycroft * Based on the flag value it either:
166 1.10 mycroft * - adds a socket to the selection list
167 1.10 mycroft * - remains in the kernel as an nfsd
168 1.10 mycroft * - remains in the kernel as an nfsiod
169 1.1 cgd */
170 1.18 christos int
171 1.16 mycroft sys_nfssvc(p, v, retval)
172 1.1 cgd struct proc *p;
173 1.15 thorpej void *v;
174 1.15 thorpej register_t *retval;
175 1.15 thorpej {
176 1.16 mycroft register struct sys_nfssvc_args /* {
177 1.13 cgd syscallarg(int) flag;
178 1.13 cgd syscallarg(caddr_t) argp;
179 1.15 thorpej } */ *uap = v;
180 1.23 thorpej int error;
181 1.24 thorpej #ifdef NFS
182 1.10 mycroft struct nameidata nd;
183 1.18 christos struct nfsmount *nmp;
184 1.19 fvdl struct nfsd_cargs ncd;
185 1.19 fvdl #endif
186 1.18 christos #ifdef NFSSERVER
187 1.1 cgd struct file *fp;
188 1.10 mycroft struct mbuf *nam;
189 1.10 mycroft struct nfsd_args nfsdarg;
190 1.10 mycroft struct nfsd_srvargs nfsd_srvargs, *nsd = &nfsd_srvargs;
191 1.10 mycroft struct nfsd *nfsd;
192 1.10 mycroft struct nfssvc_sock *slp;
193 1.18 christos struct nfsuid *nuidp;
194 1.18 christos #endif
195 1.1 cgd
196 1.1 cgd /*
197 1.1 cgd * Must be super user
198 1.1 cgd */
199 1.19 fvdl error = suser(p->p_ucred, &p->p_acflag);
200 1.19 fvdl if(error)
201 1.1 cgd return (error);
202 1.12 mycroft while (nfssvc_sockhead_flag & SLP_INIT) {
203 1.19 fvdl nfssvc_sockhead_flag |= SLP_WANTINIT;
204 1.10 mycroft (void) tsleep((caddr_t)&nfssvc_sockhead, PSOCK, "nfsd init", 0);
205 1.10 mycroft }
206 1.13 cgd if (SCARG(uap, flag) & NFSSVC_BIOD) {
207 1.24 thorpej #ifdef NFS
208 1.19 fvdl error = nfssvc_iod(p);
209 1.19 fvdl #else
210 1.10 mycroft error = ENOSYS;
211 1.19 fvdl #endif
212 1.13 cgd } else if (SCARG(uap, flag) & NFSSVC_MNTD) {
213 1.24 thorpej #ifndef NFS
214 1.10 mycroft error = ENOSYS;
215 1.19 fvdl #else
216 1.18 christos error = copyin(SCARG(uap, argp), (caddr_t)&ncd, sizeof (ncd));
217 1.18 christos if (error)
218 1.10 mycroft return (error);
219 1.10 mycroft NDINIT(&nd, LOOKUP, FOLLOW | LOCKLEAF, UIO_USERSPACE,
220 1.10 mycroft ncd.ncd_dirp, p);
221 1.19 fvdl error = namei(&nd);
222 1.19 fvdl if (error)
223 1.10 mycroft return (error);
224 1.10 mycroft if ((nd.ni_vp->v_flag & VROOT) == 0)
225 1.10 mycroft error = EINVAL;
226 1.10 mycroft nmp = VFSTONFS(nd.ni_vp->v_mount);
227 1.10 mycroft vput(nd.ni_vp);
228 1.10 mycroft if (error)
229 1.10 mycroft return (error);
230 1.27 fvdl if ((nmp->nm_iflag & NFSMNT_MNTD) &&
231 1.19 fvdl (SCARG(uap, flag) & NFSSVC_GOTAUTH) == 0)
232 1.10 mycroft return (0);
233 1.27 fvdl nmp->nm_iflag |= NFSMNT_MNTD;
234 1.13 cgd error = nqnfs_clientd(nmp, p->p_ucred, &ncd, SCARG(uap, flag),
235 1.19 fvdl SCARG(uap, argp), p);
236 1.24 thorpej #endif /* NFS */
237 1.13 cgd } else if (SCARG(uap, flag) & NFSSVC_ADDSOCK) {
238 1.10 mycroft #ifndef NFSSERVER
239 1.10 mycroft error = ENOSYS;
240 1.19 fvdl #else
241 1.18 christos error = copyin(SCARG(uap, argp), (caddr_t)&nfsdarg,
242 1.19 fvdl sizeof(nfsdarg));
243 1.18 christos if (error)
244 1.10 mycroft return (error);
245 1.19 fvdl error = getsock(p->p_fd, nfsdarg.sock, &fp);
246 1.19 fvdl if (error)
247 1.10 mycroft return (error);
248 1.10 mycroft /*
249 1.10 mycroft * Get the client address for connected sockets.
250 1.10 mycroft */
251 1.10 mycroft if (nfsdarg.name == NULL || nfsdarg.namelen == 0)
252 1.10 mycroft nam = (struct mbuf *)0;
253 1.18 christos else {
254 1.18 christos error = sockargs(&nam, nfsdarg.name, nfsdarg.namelen,
255 1.19 fvdl MT_SONAME);
256 1.18 christos if (error)
257 1.18 christos return (error);
258 1.18 christos }
259 1.10 mycroft error = nfssvc_addsock(fp, nam);
260 1.10 mycroft #endif /* !NFSSERVER */
261 1.10 mycroft } else {
262 1.10 mycroft #ifndef NFSSERVER
263 1.10 mycroft error = ENOSYS;
264 1.19 fvdl #else
265 1.18 christos error = copyin(SCARG(uap, argp), (caddr_t)nsd, sizeof (*nsd));
266 1.18 christos if (error)
267 1.10 mycroft return (error);
268 1.13 cgd if ((SCARG(uap, flag) & NFSSVC_AUTHIN) &&
269 1.19 fvdl ((nfsd = nsd->nsd_nfsd)) != NULL &&
270 1.19 fvdl (nfsd->nfsd_slp->ns_flag & SLP_VALID)) {
271 1.19 fvdl slp = nfsd->nfsd_slp;
272 1.10 mycroft
273 1.10 mycroft /*
274 1.10 mycroft * First check to see if another nfsd has already
275 1.10 mycroft * added this credential.
276 1.10 mycroft */
277 1.19 fvdl for (nuidp = NUIDHASH(slp,nsd->nsd_cr.cr_uid)->lh_first;
278 1.12 mycroft nuidp != 0; nuidp = nuidp->nu_hash.le_next) {
279 1.19 fvdl if (nuidp->nu_cr.cr_uid == nsd->nsd_cr.cr_uid &&
280 1.19 fvdl (!nfsd->nfsd_nd->nd_nam2 ||
281 1.19 fvdl netaddr_match(NU_NETFAM(nuidp),
282 1.19 fvdl &nuidp->nu_haddr, nfsd->nfsd_nd->nd_nam2)))
283 1.10 mycroft break;
284 1.10 mycroft }
285 1.19 fvdl if (nuidp) {
286 1.19 fvdl nfsrv_setcred(&nuidp->nu_cr,&nfsd->nfsd_nd->nd_cr);
287 1.19 fvdl nfsd->nfsd_nd->nd_flag |= ND_KERBFULL;
288 1.19 fvdl } else {
289 1.10 mycroft /*
290 1.10 mycroft * Nope, so we will.
291 1.10 mycroft */
292 1.10 mycroft if (slp->ns_numuids < nuidhash_max) {
293 1.10 mycroft slp->ns_numuids++;
294 1.10 mycroft nuidp = (struct nfsuid *)
295 1.10 mycroft malloc(sizeof (struct nfsuid), M_NFSUID,
296 1.10 mycroft M_WAITOK);
297 1.10 mycroft } else
298 1.10 mycroft nuidp = (struct nfsuid *)0;
299 1.10 mycroft if ((slp->ns_flag & SLP_VALID) == 0) {
300 1.10 mycroft if (nuidp)
301 1.10 mycroft free((caddr_t)nuidp, M_NFSUID);
302 1.10 mycroft } else {
303 1.10 mycroft if (nuidp == (struct nfsuid *)0) {
304 1.12 mycroft nuidp = slp->ns_uidlruhead.tqh_first;
305 1.12 mycroft LIST_REMOVE(nuidp, nu_hash);
306 1.12 mycroft TAILQ_REMOVE(&slp->ns_uidlruhead, nuidp,
307 1.12 mycroft nu_lru);
308 1.19 fvdl if (nuidp->nu_flag & NU_NAM)
309 1.19 fvdl m_freem(nuidp->nu_nam);
310 1.10 mycroft }
311 1.19 fvdl nuidp->nu_flag = 0;
312 1.10 mycroft nuidp->nu_cr = nsd->nsd_cr;
313 1.10 mycroft if (nuidp->nu_cr.cr_ngroups > NGROUPS)
314 1.19 fvdl nuidp->nu_cr.cr_ngroups = NGROUPS;
315 1.10 mycroft nuidp->nu_cr.cr_ref = 1;
316 1.19 fvdl nuidp->nu_timestamp = nsd->nsd_timestamp;
317 1.19 fvdl nuidp->nu_expire = time.tv_sec + nsd->nsd_ttl;
318 1.19 fvdl /*
319 1.19 fvdl * and save the session key in nu_key.
320 1.19 fvdl */
321 1.32 perry memcpy(nuidp->nu_key, nsd->nsd_key,
322 1.32 perry sizeof(nsd->nsd_key));
323 1.19 fvdl if (nfsd->nfsd_nd->nd_nam2) {
324 1.19 fvdl struct sockaddr_in *saddr;
325 1.19 fvdl
326 1.19 fvdl saddr = mtod(nfsd->nfsd_nd->nd_nam2,
327 1.19 fvdl struct sockaddr_in *);
328 1.19 fvdl switch (saddr->sin_family) {
329 1.19 fvdl case AF_INET:
330 1.19 fvdl nuidp->nu_flag |= NU_INETADDR;
331 1.19 fvdl nuidp->nu_inetaddr =
332 1.19 fvdl saddr->sin_addr.s_addr;
333 1.19 fvdl break;
334 1.19 fvdl case AF_ISO:
335 1.19 fvdl default:
336 1.19 fvdl nuidp->nu_flag |= NU_NAM;
337 1.19 fvdl nuidp->nu_nam = m_copym(
338 1.19 fvdl nfsd->nfsd_nd->nd_nam2, 0,
339 1.19 fvdl M_COPYALL, M_WAIT);
340 1.19 fvdl break;
341 1.19 fvdl };
342 1.19 fvdl }
343 1.12 mycroft TAILQ_INSERT_TAIL(&slp->ns_uidlruhead, nuidp,
344 1.19 fvdl nu_lru);
345 1.12 mycroft LIST_INSERT_HEAD(NUIDHASH(slp, nsd->nsd_uid),
346 1.19 fvdl nuidp, nu_hash);
347 1.19 fvdl nfsrv_setcred(&nuidp->nu_cr,
348 1.19 fvdl &nfsd->nfsd_nd->nd_cr);
349 1.19 fvdl nfsd->nfsd_nd->nd_flag |= ND_KERBFULL;
350 1.10 mycroft }
351 1.10 mycroft }
352 1.10 mycroft }
353 1.13 cgd if ((SCARG(uap, flag) & NFSSVC_AUTHINFAIL) &&
354 1.13 cgd (nfsd = nsd->nsd_nfsd))
355 1.19 fvdl nfsd->nfsd_flag |= NFSD_AUTHFAIL;
356 1.13 cgd error = nfssvc_nfsd(nsd, SCARG(uap, argp), p);
357 1.10 mycroft #endif /* !NFSSERVER */
358 1.10 mycroft }
359 1.10 mycroft if (error == EINTR || error == ERESTART)
360 1.10 mycroft error = 0;
361 1.10 mycroft return (error);
362 1.10 mycroft }
363 1.10 mycroft
364 1.10 mycroft #ifdef NFSSERVER
365 1.10 mycroft /*
366 1.10 mycroft * Adds a socket to the list for servicing by nfsds.
367 1.10 mycroft */
368 1.18 christos int
369 1.10 mycroft nfssvc_addsock(fp, mynam)
370 1.10 mycroft struct file *fp;
371 1.10 mycroft struct mbuf *mynam;
372 1.10 mycroft {
373 1.10 mycroft register struct mbuf *m;
374 1.10 mycroft register int siz;
375 1.10 mycroft register struct nfssvc_sock *slp;
376 1.10 mycroft register struct socket *so;
377 1.10 mycroft struct nfssvc_sock *tslp;
378 1.10 mycroft int error, s;
379 1.10 mycroft
380 1.1 cgd so = (struct socket *)fp->f_data;
381 1.10 mycroft tslp = (struct nfssvc_sock *)0;
382 1.10 mycroft /*
383 1.10 mycroft * Add it to the list, as required.
384 1.10 mycroft */
385 1.10 mycroft if (so->so_proto->pr_protocol == IPPROTO_UDP) {
386 1.10 mycroft tslp = nfs_udpsock;
387 1.10 mycroft if (tslp->ns_flag & SLP_VALID) {
388 1.10 mycroft m_freem(mynam);
389 1.10 mycroft return (EPERM);
390 1.10 mycroft }
391 1.10 mycroft #ifdef ISO
392 1.10 mycroft } else if (so->so_proto->pr_protocol == ISOPROTO_CLTP) {
393 1.10 mycroft tslp = nfs_cltpsock;
394 1.10 mycroft if (tslp->ns_flag & SLP_VALID) {
395 1.10 mycroft m_freem(mynam);
396 1.10 mycroft return (EPERM);
397 1.10 mycroft }
398 1.10 mycroft #endif /* ISO */
399 1.10 mycroft }
400 1.10 mycroft if (so->so_type == SOCK_STREAM)
401 1.19 fvdl siz = NFS_MAXPACKET + sizeof (u_long);
402 1.10 mycroft else
403 1.1 cgd siz = NFS_MAXPACKET;
404 1.19 fvdl error = soreserve(so, siz, siz);
405 1.19 fvdl if (error) {
406 1.10 mycroft m_freem(mynam);
407 1.10 mycroft return (error);
408 1.10 mycroft }
409 1.1 cgd
410 1.1 cgd /*
411 1.1 cgd * Set protocol specific options { for now TCP only } and
412 1.1 cgd * reserve some space. For datagram sockets, this can get called
413 1.1 cgd * repeatedly for the same socket, but that isn't harmful.
414 1.1 cgd */
415 1.10 mycroft if (so->so_type == SOCK_STREAM) {
416 1.1 cgd MGET(m, M_WAIT, MT_SOOPTS);
417 1.19 fvdl *mtod(m, int32_t *) = 1;
418 1.19 fvdl m->m_len = sizeof(int32_t);
419 1.1 cgd sosetopt(so, SOL_SOCKET, SO_KEEPALIVE, m);
420 1.1 cgd }
421 1.1 cgd if (so->so_proto->pr_domain->dom_family == AF_INET &&
422 1.10 mycroft so->so_proto->pr_protocol == IPPROTO_TCP) {
423 1.1 cgd MGET(m, M_WAIT, MT_SOOPTS);
424 1.19 fvdl *mtod(m, int32_t *) = 1;
425 1.19 fvdl m->m_len = sizeof(int32_t);
426 1.1 cgd sosetopt(so, IPPROTO_TCP, TCP_NODELAY, m);
427 1.1 cgd }
428 1.1 cgd so->so_rcv.sb_flags &= ~SB_NOINTR;
429 1.1 cgd so->so_rcv.sb_timeo = 0;
430 1.1 cgd so->so_snd.sb_flags &= ~SB_NOINTR;
431 1.1 cgd so->so_snd.sb_timeo = 0;
432 1.10 mycroft if (tslp)
433 1.10 mycroft slp = tslp;
434 1.10 mycroft else {
435 1.10 mycroft slp = (struct nfssvc_sock *)
436 1.10 mycroft malloc(sizeof (struct nfssvc_sock), M_NFSSVC, M_WAITOK);
437 1.32 perry memset((caddr_t)slp, 0, sizeof (struct nfssvc_sock));
438 1.12 mycroft TAILQ_INIT(&slp->ns_uidlruhead);
439 1.12 mycroft TAILQ_INSERT_TAIL(&nfssvc_sockhead, slp, ns_chain);
440 1.10 mycroft }
441 1.10 mycroft slp->ns_so = so;
442 1.10 mycroft slp->ns_nam = mynam;
443 1.10 mycroft fp->f_count++;
444 1.10 mycroft slp->ns_fp = fp;
445 1.14 mycroft s = splsoftnet();
446 1.10 mycroft so->so_upcallarg = (caddr_t)slp;
447 1.10 mycroft so->so_upcall = nfsrv_rcv;
448 1.29 matt so->so_rcv.sb_flags |= SB_UPCALL;
449 1.10 mycroft slp->ns_flag = (SLP_VALID | SLP_NEEDQ);
450 1.10 mycroft nfsrv_wakenfsd(slp);
451 1.10 mycroft splx(s);
452 1.10 mycroft return (0);
453 1.10 mycroft }
454 1.1 cgd
455 1.10 mycroft /*
456 1.10 mycroft * Called by nfssvc() for nfsds. Just loops around servicing rpc requests
457 1.10 mycroft * until it is killed by a signal.
458 1.10 mycroft */
459 1.18 christos int
460 1.10 mycroft nfssvc_nfsd(nsd, argp, p)
461 1.10 mycroft struct nfsd_srvargs *nsd;
462 1.10 mycroft caddr_t argp;
463 1.10 mycroft struct proc *p;
464 1.10 mycroft {
465 1.19 fvdl register struct mbuf *m;
466 1.10 mycroft register int siz;
467 1.10 mycroft register struct nfssvc_sock *slp;
468 1.10 mycroft register struct socket *so;
469 1.10 mycroft register int *solockp;
470 1.19 fvdl struct nfsd *nfsd = nsd->nsd_nfsd;
471 1.19 fvdl struct nfsrv_descript *nd = NULL;
472 1.19 fvdl struct mbuf *mreq;
473 1.19 fvdl int error = 0, cacherep, s, sotype, writes_todo;
474 1.19 fvdl u_quad_t cur_usec;
475 1.19 fvdl
476 1.19 fvdl #ifndef nolint
477 1.19 fvdl cacherep = RC_DOIT;
478 1.19 fvdl writes_todo = 0;
479 1.19 fvdl #endif
480 1.14 mycroft s = splsoftnet();
481 1.19 fvdl if (nfsd == (struct nfsd *)0) {
482 1.19 fvdl nsd->nsd_nfsd = nfsd = (struct nfsd *)
483 1.10 mycroft malloc(sizeof (struct nfsd), M_NFSD, M_WAITOK);
484 1.32 perry memset((caddr_t)nfsd, 0, sizeof (struct nfsd));
485 1.19 fvdl nfsd->nfsd_procp = p;
486 1.19 fvdl TAILQ_INSERT_TAIL(&nfsd_head, nfsd, nfsd_chain);
487 1.10 mycroft nfs_numnfsd++;
488 1.10 mycroft }
489 1.33 mycroft p->p_holdcnt++;
490 1.1 cgd /*
491 1.10 mycroft * Loop getting rpc requests until SIGKILL.
492 1.1 cgd */
493 1.1 cgd for (;;) {
494 1.19 fvdl if ((nfsd->nfsd_flag & NFSD_REQINPROG) == 0) {
495 1.19 fvdl while (nfsd->nfsd_slp == (struct nfssvc_sock *)0 &&
496 1.12 mycroft (nfsd_head_flag & NFSD_CHECKSLP) == 0) {
497 1.19 fvdl nfsd->nfsd_flag |= NFSD_WAITING;
498 1.10 mycroft nfsd_waiting++;
499 1.19 fvdl error = tsleep((caddr_t)nfsd, PSOCK | PCATCH,
500 1.19 fvdl "nfsd", 0);
501 1.10 mycroft nfsd_waiting--;
502 1.10 mycroft if (error)
503 1.10 mycroft goto done;
504 1.10 mycroft }
505 1.19 fvdl if (nfsd->nfsd_slp == (struct nfssvc_sock *)0 &&
506 1.12 mycroft (nfsd_head_flag & NFSD_CHECKSLP) != 0) {
507 1.12 mycroft for (slp = nfssvc_sockhead.tqh_first; slp != 0;
508 1.12 mycroft slp = slp->ns_chain.tqe_next) {
509 1.10 mycroft if ((slp->ns_flag & (SLP_VALID | SLP_DOREC))
510 1.10 mycroft == (SLP_VALID | SLP_DOREC)) {
511 1.10 mycroft slp->ns_flag &= ~SLP_DOREC;
512 1.10 mycroft slp->ns_sref++;
513 1.19 fvdl nfsd->nfsd_slp = slp;
514 1.10 mycroft break;
515 1.10 mycroft }
516 1.10 mycroft }
517 1.12 mycroft if (slp == 0)
518 1.12 mycroft nfsd_head_flag &= ~NFSD_CHECKSLP;
519 1.10 mycroft }
520 1.19 fvdl if ((slp = nfsd->nfsd_slp) == (struct nfssvc_sock *)0)
521 1.10 mycroft continue;
522 1.10 mycroft if (slp->ns_flag & SLP_VALID) {
523 1.10 mycroft if (slp->ns_flag & SLP_DISCONN)
524 1.10 mycroft nfsrv_zapsock(slp);
525 1.10 mycroft else if (slp->ns_flag & SLP_NEEDQ) {
526 1.10 mycroft slp->ns_flag &= ~SLP_NEEDQ;
527 1.10 mycroft (void) nfs_sndlock(&slp->ns_solock,
528 1.10 mycroft (struct nfsreq *)0);
529 1.10 mycroft nfsrv_rcv(slp->ns_so, (caddr_t)slp,
530 1.10 mycroft M_WAIT);
531 1.10 mycroft nfs_sndunlock(&slp->ns_solock);
532 1.10 mycroft }
533 1.19 fvdl error = nfsrv_dorec(slp, nfsd, &nd);
534 1.19 fvdl cur_usec = (u_quad_t)time.tv_sec * 1000000 +
535 1.19 fvdl (u_quad_t)time.tv_usec;
536 1.19 fvdl if (error && slp->ns_tq.lh_first &&
537 1.19 fvdl slp->ns_tq.lh_first->nd_time <= cur_usec) {
538 1.19 fvdl error = 0;
539 1.19 fvdl cacherep = RC_DOIT;
540 1.19 fvdl writes_todo = 1;
541 1.19 fvdl } else
542 1.19 fvdl writes_todo = 0;
543 1.19 fvdl nfsd->nfsd_flag |= NFSD_REQINPROG;
544 1.1 cgd }
545 1.10 mycroft } else {
546 1.10 mycroft error = 0;
547 1.19 fvdl slp = nfsd->nfsd_slp;
548 1.10 mycroft }
549 1.10 mycroft if (error || (slp->ns_flag & SLP_VALID) == 0) {
550 1.19 fvdl if (nd) {
551 1.19 fvdl free((caddr_t)nd, M_NFSRVDESC);
552 1.19 fvdl nd = NULL;
553 1.19 fvdl }
554 1.19 fvdl nfsd->nfsd_slp = (struct nfssvc_sock *)0;
555 1.19 fvdl nfsd->nfsd_flag &= ~NFSD_REQINPROG;
556 1.10 mycroft nfsrv_slpderef(slp);
557 1.1 cgd continue;
558 1.1 cgd }
559 1.10 mycroft splx(s);
560 1.10 mycroft so = slp->ns_so;
561 1.10 mycroft sotype = so->so_type;
562 1.10 mycroft if (so->so_proto->pr_flags & PR_CONNREQUIRED)
563 1.10 mycroft solockp = &slp->ns_solock;
564 1.10 mycroft else
565 1.10 mycroft solockp = (int *)0;
566 1.19 fvdl if (nd) {
567 1.19 fvdl nd->nd_starttime = time;
568 1.19 fvdl if (nd->nd_nam2)
569 1.19 fvdl nd->nd_nam = nd->nd_nam2;
570 1.19 fvdl else
571 1.19 fvdl nd->nd_nam = slp->ns_nam;
572 1.19 fvdl
573 1.19 fvdl /*
574 1.19 fvdl * Check to see if authorization is needed.
575 1.19 fvdl */
576 1.19 fvdl if (nfsd->nfsd_flag & NFSD_NEEDAUTH) {
577 1.19 fvdl nfsd->nfsd_flag &= ~NFSD_NEEDAUTH;
578 1.19 fvdl nsd->nsd_haddr = mtod(nd->nd_nam,
579 1.19 fvdl struct sockaddr_in *)->sin_addr.s_addr;
580 1.19 fvdl nsd->nsd_authlen = nfsd->nfsd_authlen;
581 1.19 fvdl nsd->nsd_verflen = nfsd->nfsd_verflen;
582 1.19 fvdl if (!copyout(nfsd->nfsd_authstr,nsd->nsd_authstr,
583 1.19 fvdl nfsd->nfsd_authlen) &&
584 1.19 fvdl !copyout(nfsd->nfsd_verfstr, nsd->nsd_verfstr,
585 1.19 fvdl nfsd->nfsd_verflen) &&
586 1.33 mycroft !copyout((caddr_t)nsd, argp, sizeof (*nsd))) {
587 1.33 mycroft p->p_holdcnt--;
588 1.19 fvdl return (ENEEDAUTH);
589 1.33 mycroft }
590 1.19 fvdl cacherep = RC_DROPIT;
591 1.19 fvdl } else
592 1.19 fvdl cacherep = nfsrv_getcache(nd, slp, &mreq);
593 1.19 fvdl
594 1.19 fvdl /*
595 1.19 fvdl * Check for just starting up for NQNFS and send
596 1.19 fvdl * fake "try again later" replies to the NQNFS clients.
597 1.19 fvdl */
598 1.19 fvdl if (notstarted && nqnfsstarttime <= time.tv_sec) {
599 1.10 mycroft if (modify_flag) {
600 1.10 mycroft nqnfsstarttime = time.tv_sec + nqsrv_writeslack;
601 1.10 mycroft modify_flag = 0;
602 1.10 mycroft } else
603 1.10 mycroft notstarted = 0;
604 1.19 fvdl }
605 1.19 fvdl if (notstarted) {
606 1.19 fvdl if ((nd->nd_flag & ND_NQNFS) == 0)
607 1.10 mycroft cacherep = RC_DROPIT;
608 1.10 mycroft else if (nd->nd_procnum != NFSPROC_WRITE) {
609 1.10 mycroft nd->nd_procnum = NFSPROC_NOOP;
610 1.10 mycroft nd->nd_repstat = NQNFS_TRYLATER;
611 1.10 mycroft cacherep = RC_DOIT;
612 1.10 mycroft } else
613 1.10 mycroft modify_flag = 1;
614 1.19 fvdl } else if (nfsd->nfsd_flag & NFSD_AUTHFAIL) {
615 1.19 fvdl nfsd->nfsd_flag &= ~NFSD_AUTHFAIL;
616 1.10 mycroft nd->nd_procnum = NFSPROC_NOOP;
617 1.19 fvdl nd->nd_repstat = (NFSERR_AUTHERR | AUTH_TOOWEAK);
618 1.1 cgd cacherep = RC_DOIT;
619 1.19 fvdl }
620 1.10 mycroft }
621 1.10 mycroft
622 1.19 fvdl /*
623 1.19 fvdl * Loop to get all the write rpc relies that have been
624 1.19 fvdl * gathered together.
625 1.19 fvdl */
626 1.19 fvdl do {
627 1.19 fvdl switch (cacherep) {
628 1.19 fvdl case RC_DOIT:
629 1.19 fvdl if (writes_todo || (nd->nd_procnum == NFSPROC_WRITE &&
630 1.19 fvdl nfsrvw_procrastinate > 0 && !notstarted))
631 1.19 fvdl error = nfsrv_writegather(&nd, slp,
632 1.19 fvdl nfsd->nfsd_procp, &mreq);
633 1.19 fvdl else
634 1.19 fvdl error = (*(nfsrv3_procs[nd->nd_procnum]))(nd,
635 1.19 fvdl slp, nfsd->nfsd_procp, &mreq);
636 1.19 fvdl if (mreq == NULL)
637 1.19 fvdl break;
638 1.10 mycroft if (error) {
639 1.10 mycroft if (nd->nd_procnum != NQNFSPROC_VACATED)
640 1.10 mycroft nfsstats.srv_errs++;
641 1.19 fvdl nfsrv_updatecache(nd, FALSE, mreq);
642 1.19 fvdl if (nd->nd_nam2)
643 1.19 fvdl m_freem(nd->nd_nam2);
644 1.1 cgd break;
645 1.1 cgd }
646 1.10 mycroft nfsstats.srvrpccnt[nd->nd_procnum]++;
647 1.19 fvdl nfsrv_updatecache(nd, TRUE, mreq);
648 1.10 mycroft nd->nd_mrep = (struct mbuf *)0;
649 1.19 fvdl case RC_REPLY:
650 1.1 cgd m = mreq;
651 1.1 cgd siz = 0;
652 1.1 cgd while (m) {
653 1.1 cgd siz += m->m_len;
654 1.1 cgd m = m->m_next;
655 1.1 cgd }
656 1.1 cgd if (siz <= 0 || siz > NFS_MAXPACKET) {
657 1.21 christos printf("mbuf siz=%d\n",siz);
658 1.1 cgd panic("Bad nfs svc reply");
659 1.1 cgd }
660 1.10 mycroft m = mreq;
661 1.10 mycroft m->m_pkthdr.len = siz;
662 1.10 mycroft m->m_pkthdr.rcvif = (struct ifnet *)0;
663 1.1 cgd /*
664 1.10 mycroft * For stream protocols, prepend a Sun RPC
665 1.1 cgd * Record Mark.
666 1.1 cgd */
667 1.10 mycroft if (sotype == SOCK_STREAM) {
668 1.10 mycroft M_PREPEND(m, NFSX_UNSIGNED, M_WAIT);
669 1.17 cgd *mtod(m, u_int32_t *) = htonl(0x80000000 | siz);
670 1.10 mycroft }
671 1.10 mycroft if (solockp)
672 1.10 mycroft (void) nfs_sndlock(solockp, (struct nfsreq *)0);
673 1.10 mycroft if (slp->ns_flag & SLP_VALID)
674 1.19 fvdl error = nfs_send(so, nd->nd_nam2, m, NULL);
675 1.10 mycroft else {
676 1.10 mycroft error = EPIPE;
677 1.10 mycroft m_freem(m);
678 1.10 mycroft }
679 1.10 mycroft if (nfsrtton)
680 1.19 fvdl nfsd_rt(sotype, nd, cacherep);
681 1.19 fvdl if (nd->nd_nam2)
682 1.19 fvdl MFREE(nd->nd_nam2, m);
683 1.10 mycroft if (nd->nd_mrep)
684 1.10 mycroft m_freem(nd->nd_mrep);
685 1.10 mycroft if (error == EPIPE)
686 1.10 mycroft nfsrv_zapsock(slp);
687 1.10 mycroft if (solockp)
688 1.10 mycroft nfs_sndunlock(solockp);
689 1.10 mycroft if (error == EINTR || error == ERESTART) {
690 1.19 fvdl free((caddr_t)nd, M_NFSRVDESC);
691 1.10 mycroft nfsrv_slpderef(slp);
692 1.14 mycroft s = splsoftnet();
693 1.10 mycroft goto done;
694 1.1 cgd }
695 1.1 cgd break;
696 1.19 fvdl case RC_DROPIT:
697 1.10 mycroft if (nfsrtton)
698 1.19 fvdl nfsd_rt(sotype, nd, cacherep);
699 1.10 mycroft m_freem(nd->nd_mrep);
700 1.19 fvdl m_freem(nd->nd_nam2);
701 1.1 cgd break;
702 1.19 fvdl };
703 1.19 fvdl if (nd) {
704 1.19 fvdl FREE((caddr_t)nd, M_NFSRVDESC);
705 1.19 fvdl nd = NULL;
706 1.19 fvdl }
707 1.19 fvdl
708 1.19 fvdl /*
709 1.19 fvdl * Check to see if there are outstanding writes that
710 1.19 fvdl * need to be serviced.
711 1.19 fvdl */
712 1.19 fvdl cur_usec = (u_quad_t)time.tv_sec * 1000000 +
713 1.19 fvdl (u_quad_t)time.tv_usec;
714 1.19 fvdl s = splsoftclock();
715 1.19 fvdl if (slp->ns_tq.lh_first &&
716 1.19 fvdl slp->ns_tq.lh_first->nd_time <= cur_usec) {
717 1.19 fvdl cacherep = RC_DOIT;
718 1.19 fvdl writes_todo = 1;
719 1.19 fvdl } else
720 1.19 fvdl writes_todo = 0;
721 1.19 fvdl splx(s);
722 1.19 fvdl } while (writes_todo);
723 1.14 mycroft s = splsoftnet();
724 1.19 fvdl if (nfsrv_dorec(slp, nfsd, &nd)) {
725 1.19 fvdl nfsd->nfsd_flag &= ~NFSD_REQINPROG;
726 1.19 fvdl nfsd->nfsd_slp = NULL;
727 1.10 mycroft nfsrv_slpderef(slp);
728 1.10 mycroft }
729 1.1 cgd }
730 1.10 mycroft done:
731 1.33 mycroft p->p_holdcnt--;
732 1.19 fvdl TAILQ_REMOVE(&nfsd_head, nfsd, nfsd_chain);
733 1.10 mycroft splx(s);
734 1.19 fvdl free((caddr_t)nfsd, M_NFSD);
735 1.10 mycroft nsd->nsd_nfsd = (struct nfsd *)0;
736 1.10 mycroft if (--nfs_numnfsd == 0)
737 1.10 mycroft nfsrv_init(TRUE); /* Reinitialize everything */
738 1.1 cgd return (error);
739 1.1 cgd }
740 1.1 cgd
741 1.10 mycroft /*
742 1.10 mycroft * Shut down a socket associated with an nfssvc_sock structure.
743 1.10 mycroft * Should be called with the send lock set, if required.
744 1.10 mycroft * The trick here is to increment the sref at the start, so that the nfsds
745 1.10 mycroft * will stop using it and clear ns_flag at the end so that it will not be
746 1.10 mycroft * reassigned during cleanup.
747 1.10 mycroft */
748 1.18 christos void
749 1.10 mycroft nfsrv_zapsock(slp)
750 1.10 mycroft register struct nfssvc_sock *slp;
751 1.10 mycroft {
752 1.12 mycroft register struct nfsuid *nuidp, *nnuidp;
753 1.19 fvdl register struct nfsrv_descript *nwp, *nnwp;
754 1.10 mycroft struct socket *so;
755 1.10 mycroft struct file *fp;
756 1.10 mycroft struct mbuf *m;
757 1.19 fvdl int s;
758 1.10 mycroft
759 1.10 mycroft slp->ns_flag &= ~SLP_ALLFLAGS;
760 1.19 fvdl fp = slp->ns_fp;
761 1.19 fvdl if (fp) {
762 1.10 mycroft slp->ns_fp = (struct file *)0;
763 1.10 mycroft so = slp->ns_so;
764 1.10 mycroft so->so_upcall = NULL;
765 1.29 matt so->so_upcallarg = NULL;
766 1.29 matt so->so_rcv.sb_flags &= ~SB_UPCALL;
767 1.10 mycroft soshutdown(so, 2);
768 1.10 mycroft closef(fp, (struct proc *)0);
769 1.10 mycroft if (slp->ns_nam)
770 1.10 mycroft MFREE(slp->ns_nam, m);
771 1.10 mycroft m_freem(slp->ns_raw);
772 1.10 mycroft m_freem(slp->ns_rec);
773 1.12 mycroft for (nuidp = slp->ns_uidlruhead.tqh_first; nuidp != 0;
774 1.12 mycroft nuidp = nnuidp) {
775 1.12 mycroft nnuidp = nuidp->nu_lru.tqe_next;
776 1.12 mycroft LIST_REMOVE(nuidp, nu_hash);
777 1.12 mycroft TAILQ_REMOVE(&slp->ns_uidlruhead, nuidp, nu_lru);
778 1.19 fvdl if (nuidp->nu_flag & NU_NAM)
779 1.19 fvdl m_freem(nuidp->nu_nam);
780 1.12 mycroft free((caddr_t)nuidp, M_NFSUID);
781 1.12 mycroft }
782 1.19 fvdl s = splsoftclock();
783 1.19 fvdl for (nwp = slp->ns_tq.lh_first; nwp; nwp = nnwp) {
784 1.19 fvdl nnwp = nwp->nd_tq.le_next;
785 1.19 fvdl LIST_REMOVE(nwp, nd_tq);
786 1.19 fvdl free((caddr_t)nwp, M_NFSRVDESC);
787 1.19 fvdl }
788 1.19 fvdl LIST_INIT(&slp->ns_tq);
789 1.19 fvdl splx(s);
790 1.10 mycroft }
791 1.10 mycroft }
792 1.10 mycroft
793 1.10 mycroft /*
794 1.10 mycroft * Derefence a server socket structure. If it has no more references and
795 1.10 mycroft * is no longer valid, you can throw it away.
796 1.10 mycroft */
797 1.10 mycroft void
798 1.10 mycroft nfsrv_slpderef(slp)
799 1.10 mycroft register struct nfssvc_sock *slp;
800 1.10 mycroft {
801 1.10 mycroft if (--(slp->ns_sref) == 0 && (slp->ns_flag & SLP_VALID) == 0) {
802 1.12 mycroft TAILQ_REMOVE(&nfssvc_sockhead, slp, ns_chain);
803 1.10 mycroft free((caddr_t)slp, M_NFSSVC);
804 1.10 mycroft }
805 1.10 mycroft }
806 1.10 mycroft
807 1.10 mycroft /*
808 1.10 mycroft * Initialize the data structures for the server.
809 1.10 mycroft * Handshake with any new nfsds starting up to avoid any chance of
810 1.10 mycroft * corruption.
811 1.10 mycroft */
812 1.10 mycroft void
813 1.10 mycroft nfsrv_init(terminating)
814 1.10 mycroft int terminating;
815 1.10 mycroft {
816 1.12 mycroft register struct nfssvc_sock *slp, *nslp;
817 1.10 mycroft
818 1.12 mycroft if (nfssvc_sockhead_flag & SLP_INIT)
819 1.10 mycroft panic("nfsd init");
820 1.12 mycroft nfssvc_sockhead_flag |= SLP_INIT;
821 1.10 mycroft if (terminating) {
822 1.12 mycroft for (slp = nfssvc_sockhead.tqh_first; slp != 0; slp = nslp) {
823 1.12 mycroft nslp = slp->ns_chain.tqe_next;
824 1.10 mycroft if (slp->ns_flag & SLP_VALID)
825 1.10 mycroft nfsrv_zapsock(slp);
826 1.12 mycroft TAILQ_REMOVE(&nfssvc_sockhead, slp, ns_chain);
827 1.12 mycroft free((caddr_t)slp, M_NFSSVC);
828 1.10 mycroft }
829 1.10 mycroft nfsrv_cleancache(); /* And clear out server cache */
830 1.26 fvdl } else
831 1.26 fvdl nfs_pub.np_valid = 0;
832 1.12 mycroft
833 1.12 mycroft TAILQ_INIT(&nfssvc_sockhead);
834 1.12 mycroft nfssvc_sockhead_flag &= ~SLP_INIT;
835 1.12 mycroft if (nfssvc_sockhead_flag & SLP_WANTINIT) {
836 1.12 mycroft nfssvc_sockhead_flag &= ~SLP_WANTINIT;
837 1.12 mycroft wakeup((caddr_t)&nfssvc_sockhead);
838 1.12 mycroft }
839 1.12 mycroft
840 1.12 mycroft TAILQ_INIT(&nfsd_head);
841 1.12 mycroft nfsd_head_flag &= ~NFSD_CHECKSLP;
842 1.12 mycroft
843 1.10 mycroft nfs_udpsock = (struct nfssvc_sock *)
844 1.10 mycroft malloc(sizeof (struct nfssvc_sock), M_NFSSVC, M_WAITOK);
845 1.32 perry memset((caddr_t)nfs_udpsock, 0, sizeof (struct nfssvc_sock));
846 1.12 mycroft TAILQ_INIT(&nfs_udpsock->ns_uidlruhead);
847 1.12 mycroft TAILQ_INSERT_HEAD(&nfssvc_sockhead, nfs_udpsock, ns_chain);
848 1.12 mycroft
849 1.10 mycroft nfs_cltpsock = (struct nfssvc_sock *)
850 1.10 mycroft malloc(sizeof (struct nfssvc_sock), M_NFSSVC, M_WAITOK);
851 1.32 perry memset((caddr_t)nfs_cltpsock, 0, sizeof (struct nfssvc_sock));
852 1.12 mycroft TAILQ_INIT(&nfs_cltpsock->ns_uidlruhead);
853 1.12 mycroft TAILQ_INSERT_TAIL(&nfssvc_sockhead, nfs_cltpsock, ns_chain);
854 1.10 mycroft }
855 1.10 mycroft
856 1.10 mycroft /*
857 1.10 mycroft * Add entries to the server monitor log.
858 1.10 mycroft */
859 1.10 mycroft static void
860 1.19 fvdl nfsd_rt(sotype, nd, cacherep)
861 1.10 mycroft int sotype;
862 1.19 fvdl register struct nfsrv_descript *nd;
863 1.10 mycroft int cacherep;
864 1.10 mycroft {
865 1.10 mycroft register struct drt *rt;
866 1.10 mycroft
867 1.10 mycroft rt = &nfsdrt.drt[nfsdrt.pos];
868 1.10 mycroft if (cacherep == RC_DOIT)
869 1.10 mycroft rt->flag = 0;
870 1.10 mycroft else if (cacherep == RC_REPLY)
871 1.10 mycroft rt->flag = DRT_CACHEREPLY;
872 1.10 mycroft else
873 1.10 mycroft rt->flag = DRT_CACHEDROP;
874 1.10 mycroft if (sotype == SOCK_STREAM)
875 1.10 mycroft rt->flag |= DRT_TCP;
876 1.19 fvdl if (nd->nd_flag & ND_NQNFS)
877 1.10 mycroft rt->flag |= DRT_NQNFS;
878 1.19 fvdl else if (nd->nd_flag & ND_NFSV3)
879 1.19 fvdl rt->flag |= DRT_NFSV3;
880 1.10 mycroft rt->proc = nd->nd_procnum;
881 1.19 fvdl if (mtod(nd->nd_nam, struct sockaddr *)->sa_family == AF_INET)
882 1.19 fvdl rt->ipadr = mtod(nd->nd_nam, struct sockaddr_in *)->sin_addr.s_addr;
883 1.10 mycroft else
884 1.19 fvdl rt->ipadr = INADDR_ANY;
885 1.19 fvdl rt->resptime = ((time.tv_sec - nd->nd_starttime.tv_sec) * 1000000) +
886 1.19 fvdl (time.tv_usec - nd->nd_starttime.tv_usec);
887 1.10 mycroft rt->tstamp = time;
888 1.10 mycroft nfsdrt.pos = (nfsdrt.pos + 1) % NFSRTTLOGSIZ;
889 1.10 mycroft }
890 1.3 glass #endif /* NFSSERVER */
891 1.3 glass
892 1.24 thorpej #ifdef NFS
893 1.22 thorpej
894 1.22 thorpej int nfs_defect = 0;
895 1.1 cgd /*
896 1.10 mycroft * Asynchronous I/O daemons for client nfs.
897 1.10 mycroft * They do read-ahead and write-behind operations on the block I/O cache.
898 1.10 mycroft * Never returns unless it fails or gets killed.
899 1.1 cgd */
900 1.18 christos int
901 1.10 mycroft nfssvc_iod(p)
902 1.1 cgd struct proc *p;
903 1.1 cgd {
904 1.22 thorpej register struct buf *bp;
905 1.1 cgd register int i, myiod;
906 1.22 thorpej struct nfsmount *nmp;
907 1.22 thorpej int error = 0;
908 1.1 cgd
909 1.1 cgd /*
910 1.1 cgd * Assign my position or return error if too many already running
911 1.1 cgd */
912 1.1 cgd myiod = -1;
913 1.1 cgd for (i = 0; i < NFS_MAXASYNCDAEMON; i++)
914 1.1 cgd if (nfs_asyncdaemon[i] == 0) {
915 1.1 cgd myiod = i;
916 1.1 cgd break;
917 1.1 cgd }
918 1.1 cgd if (myiod == -1)
919 1.1 cgd return (EBUSY);
920 1.33 mycroft nfs_asyncdaemon[myiod] = 1;
921 1.1 cgd nfs_numasync++;
922 1.33 mycroft p->p_holdcnt++;
923 1.1 cgd /*
924 1.1 cgd * Just loop around doin our stuff until SIGKILL
925 1.1 cgd */
926 1.1 cgd for (;;) {
927 1.22 thorpej while (((nmp = nfs_iodmount[myiod]) == NULL
928 1.22 thorpej || nmp->nm_bufq.tqh_first == NULL)
929 1.22 thorpej && error == 0) {
930 1.22 thorpej if (nmp)
931 1.22 thorpej nmp->nm_bufqiods--;
932 1.19 fvdl nfs_iodwant[myiod] = p;
933 1.22 thorpej nfs_iodmount[myiod] = NULL;
934 1.19 fvdl error = tsleep((caddr_t)&nfs_iodwant[myiod],
935 1.19 fvdl PWAIT | PCATCH, "nfsidl", 0);
936 1.19 fvdl }
937 1.22 thorpej if (error) {
938 1.22 thorpej if (nmp)
939 1.22 thorpej nmp->nm_bufqiods--;
940 1.22 thorpej nfs_iodmount[myiod] = NULL;
941 1.33 mycroft break;
942 1.22 thorpej }
943 1.22 thorpej while ((bp = nmp->nm_bufq.tqh_first) != NULL) {
944 1.19 fvdl /* Take one off the front of the list */
945 1.22 thorpej TAILQ_REMOVE(&nmp->nm_bufq, bp, b_freelist);
946 1.22 thorpej nmp->nm_bufqlen--;
947 1.22 thorpej if (nmp->nm_bufqwant && nmp->nm_bufqlen < 2 * nfs_numasync) {
948 1.22 thorpej nmp->nm_bufqwant = FALSE;
949 1.22 thorpej wakeup(&nmp->nm_bufq);
950 1.22 thorpej }
951 1.19 fvdl if (bp->b_flags & B_READ)
952 1.19 fvdl (void) nfs_doio(bp, bp->b_rcred, (struct proc *)0);
953 1.22 thorpej else
954 1.19 fvdl (void) nfs_doio(bp, bp->b_wcred, (struct proc *)0);
955 1.22 thorpej /*
956 1.22 thorpej * If there are more than one iod on this mount, then defect
957 1.22 thorpej * so that the iods can be shared out fairly between the mounts
958 1.22 thorpej */
959 1.22 thorpej if (nfs_defect && nmp->nm_bufqiods > 1) {
960 1.22 thorpej nfs_iodmount[myiod] = NULL;
961 1.22 thorpej nmp->nm_bufqiods--;
962 1.22 thorpej break;
963 1.22 thorpej }
964 1.19 fvdl }
965 1.1 cgd }
966 1.33 mycroft p->p_holdcnt--;
967 1.33 mycroft nfs_asyncdaemon[myiod] = 0;
968 1.33 mycroft nfs_numasync--;
969 1.33 mycroft return (error);
970 1.1 cgd }
971 1.3 glass
972 1.19 fvdl
973 1.10 mycroft /*
974 1.10 mycroft * Get an authorization string for the uid by having the mount_nfs sitting
975 1.10 mycroft * on this mount point porpous out of the kernel and do it.
976 1.10 mycroft */
977 1.18 christos int
978 1.19 fvdl nfs_getauth(nmp, rep, cred, auth_str, auth_len, verf_str, verf_len, key)
979 1.10 mycroft register struct nfsmount *nmp;
980 1.10 mycroft struct nfsreq *rep;
981 1.10 mycroft struct ucred *cred;
982 1.10 mycroft char **auth_str;
983 1.10 mycroft int *auth_len;
984 1.19 fvdl char *verf_str;
985 1.19 fvdl int *verf_len;
986 1.19 fvdl NFSKERBKEY_T key; /* return session key */
987 1.10 mycroft {
988 1.10 mycroft int error = 0;
989 1.10 mycroft
990 1.27 fvdl while ((nmp->nm_iflag & NFSMNT_WAITAUTH) == 0) {
991 1.27 fvdl nmp->nm_iflag |= NFSMNT_WANTAUTH;
992 1.10 mycroft (void) tsleep((caddr_t)&nmp->nm_authtype, PSOCK,
993 1.10 mycroft "nfsauth1", 2 * hz);
994 1.18 christos error = nfs_sigintr(nmp, rep, rep->r_procp);
995 1.18 christos if (error) {
996 1.27 fvdl nmp->nm_iflag &= ~NFSMNT_WANTAUTH;
997 1.10 mycroft return (error);
998 1.10 mycroft }
999 1.10 mycroft }
1000 1.27 fvdl nmp->nm_iflag &= ~(NFSMNT_WAITAUTH | NFSMNT_WANTAUTH);
1001 1.10 mycroft nmp->nm_authstr = *auth_str = (char *)malloc(RPCAUTH_MAXSIZ, M_TEMP, M_WAITOK);
1002 1.19 fvdl nmp->nm_authlen = RPCAUTH_MAXSIZ;
1003 1.19 fvdl nmp->nm_verfstr = verf_str;
1004 1.19 fvdl nmp->nm_verflen = *verf_len;
1005 1.10 mycroft nmp->nm_authuid = cred->cr_uid;
1006 1.10 mycroft wakeup((caddr_t)&nmp->nm_authstr);
1007 1.3 glass
1008 1.10 mycroft /*
1009 1.10 mycroft * And wait for mount_nfs to do its stuff.
1010 1.10 mycroft */
1011 1.27 fvdl while ((nmp->nm_iflag & NFSMNT_HASAUTH) == 0 && error == 0) {
1012 1.10 mycroft (void) tsleep((caddr_t)&nmp->nm_authlen, PSOCK,
1013 1.10 mycroft "nfsauth2", 2 * hz);
1014 1.10 mycroft error = nfs_sigintr(nmp, rep, rep->r_procp);
1015 1.10 mycroft }
1016 1.27 fvdl if (nmp->nm_iflag & NFSMNT_AUTHERR) {
1017 1.27 fvdl nmp->nm_iflag &= ~NFSMNT_AUTHERR;
1018 1.10 mycroft error = EAUTH;
1019 1.10 mycroft }
1020 1.10 mycroft if (error)
1021 1.10 mycroft free((caddr_t)*auth_str, M_TEMP);
1022 1.10 mycroft else {
1023 1.10 mycroft *auth_len = nmp->nm_authlen;
1024 1.19 fvdl *verf_len = nmp->nm_verflen;
1025 1.32 perry memcpy((caddr_t)key, (caddr_t)nmp->nm_key, sizeof (key));
1026 1.10 mycroft }
1027 1.27 fvdl nmp->nm_iflag &= ~NFSMNT_HASAUTH;
1028 1.27 fvdl nmp->nm_iflag |= NFSMNT_WAITAUTH;
1029 1.27 fvdl if (nmp->nm_iflag & NFSMNT_WANTAUTH) {
1030 1.27 fvdl nmp->nm_iflag &= ~NFSMNT_WANTAUTH;
1031 1.10 mycroft wakeup((caddr_t)&nmp->nm_authtype);
1032 1.10 mycroft }
1033 1.19 fvdl return (error);
1034 1.19 fvdl }
1035 1.19 fvdl
1036 1.19 fvdl /*
1037 1.19 fvdl * Get a nickname authenticator and verifier.
1038 1.19 fvdl */
1039 1.19 fvdl int
1040 1.19 fvdl nfs_getnickauth(nmp, cred, auth_str, auth_len, verf_str, verf_len)
1041 1.19 fvdl struct nfsmount *nmp;
1042 1.19 fvdl struct ucred *cred;
1043 1.19 fvdl char **auth_str;
1044 1.19 fvdl int *auth_len;
1045 1.19 fvdl char *verf_str;
1046 1.19 fvdl int verf_len;
1047 1.19 fvdl {
1048 1.19 fvdl register struct nfsuid *nuidp;
1049 1.19 fvdl register u_int32_t *nickp, *verfp;
1050 1.19 fvdl struct timeval ktvin, ktvout;
1051 1.19 fvdl
1052 1.19 fvdl #ifdef DIAGNOSTIC
1053 1.19 fvdl if (verf_len < (4 * NFSX_UNSIGNED))
1054 1.19 fvdl panic("nfs_getnickauth verf too small");
1055 1.19 fvdl #endif
1056 1.19 fvdl for (nuidp = NMUIDHASH(nmp, cred->cr_uid)->lh_first;
1057 1.19 fvdl nuidp != 0; nuidp = nuidp->nu_hash.le_next) {
1058 1.19 fvdl if (nuidp->nu_cr.cr_uid == cred->cr_uid)
1059 1.19 fvdl break;
1060 1.19 fvdl }
1061 1.19 fvdl if (!nuidp || nuidp->nu_expire < time.tv_sec)
1062 1.19 fvdl return (EACCES);
1063 1.19 fvdl
1064 1.19 fvdl /*
1065 1.19 fvdl * Move to the end of the lru list (end of lru == most recently used).
1066 1.19 fvdl */
1067 1.19 fvdl TAILQ_REMOVE(&nmp->nm_uidlruhead, nuidp, nu_lru);
1068 1.19 fvdl TAILQ_INSERT_TAIL(&nmp->nm_uidlruhead, nuidp, nu_lru);
1069 1.19 fvdl
1070 1.19 fvdl nickp = (u_int32_t *)malloc(2 * NFSX_UNSIGNED, M_TEMP, M_WAITOK);
1071 1.19 fvdl *nickp++ = txdr_unsigned(RPCAKN_NICKNAME);
1072 1.19 fvdl *nickp = txdr_unsigned(nuidp->nu_nickname);
1073 1.19 fvdl *auth_str = (char *)nickp;
1074 1.19 fvdl *auth_len = 2 * NFSX_UNSIGNED;
1075 1.19 fvdl
1076 1.19 fvdl /*
1077 1.19 fvdl * Now we must encrypt the verifier and package it up.
1078 1.19 fvdl */
1079 1.19 fvdl verfp = (u_int32_t *)verf_str;
1080 1.19 fvdl *verfp++ = txdr_unsigned(RPCAKN_NICKNAME);
1081 1.19 fvdl if (time.tv_sec > nuidp->nu_timestamp.tv_sec ||
1082 1.19 fvdl (time.tv_sec == nuidp->nu_timestamp.tv_sec &&
1083 1.19 fvdl time.tv_usec > nuidp->nu_timestamp.tv_usec))
1084 1.19 fvdl nuidp->nu_timestamp = time;
1085 1.19 fvdl else
1086 1.19 fvdl nuidp->nu_timestamp.tv_usec++;
1087 1.19 fvdl ktvin.tv_sec = txdr_unsigned(nuidp->nu_timestamp.tv_sec);
1088 1.19 fvdl ktvin.tv_usec = txdr_unsigned(nuidp->nu_timestamp.tv_usec);
1089 1.19 fvdl
1090 1.19 fvdl /*
1091 1.19 fvdl * Now encrypt the timestamp verifier in ecb mode using the session
1092 1.19 fvdl * key.
1093 1.19 fvdl */
1094 1.19 fvdl #ifdef NFSKERB
1095 1.19 fvdl XXX
1096 1.19 fvdl #endif
1097 1.19 fvdl
1098 1.19 fvdl *verfp++ = ktvout.tv_sec;
1099 1.19 fvdl *verfp++ = ktvout.tv_usec;
1100 1.19 fvdl *verfp = 0;
1101 1.19 fvdl return (0);
1102 1.19 fvdl }
1103 1.19 fvdl
1104 1.19 fvdl /*
1105 1.19 fvdl * Save the current nickname in a hash list entry on the mount point.
1106 1.19 fvdl */
1107 1.19 fvdl int
1108 1.19 fvdl nfs_savenickauth(nmp, cred, len, key, mdp, dposp, mrep)
1109 1.19 fvdl register struct nfsmount *nmp;
1110 1.19 fvdl struct ucred *cred;
1111 1.19 fvdl int len;
1112 1.19 fvdl NFSKERBKEY_T key;
1113 1.19 fvdl struct mbuf **mdp;
1114 1.19 fvdl char **dposp;
1115 1.19 fvdl struct mbuf *mrep;
1116 1.19 fvdl {
1117 1.19 fvdl register struct nfsuid *nuidp;
1118 1.19 fvdl register u_int32_t *tl;
1119 1.19 fvdl register int32_t t1;
1120 1.19 fvdl struct mbuf *md = *mdp;
1121 1.19 fvdl struct timeval ktvin, ktvout;
1122 1.19 fvdl u_int32_t nick;
1123 1.19 fvdl char *dpos = *dposp, *cp2;
1124 1.19 fvdl int deltasec, error = 0;
1125 1.19 fvdl
1126 1.19 fvdl if (len == (3 * NFSX_UNSIGNED)) {
1127 1.19 fvdl nfsm_dissect(tl, u_int32_t *, 3 * NFSX_UNSIGNED);
1128 1.19 fvdl ktvin.tv_sec = *tl++;
1129 1.19 fvdl ktvin.tv_usec = *tl++;
1130 1.19 fvdl nick = fxdr_unsigned(u_int32_t, *tl);
1131 1.19 fvdl
1132 1.19 fvdl /*
1133 1.19 fvdl * Decrypt the timestamp in ecb mode.
1134 1.19 fvdl */
1135 1.19 fvdl #ifdef NFSKERB
1136 1.19 fvdl XXX
1137 1.19 fvdl #endif
1138 1.19 fvdl ktvout.tv_sec = fxdr_unsigned(long, ktvout.tv_sec);
1139 1.19 fvdl ktvout.tv_usec = fxdr_unsigned(long, ktvout.tv_usec);
1140 1.19 fvdl deltasec = time.tv_sec - ktvout.tv_sec;
1141 1.19 fvdl if (deltasec < 0)
1142 1.19 fvdl deltasec = -deltasec;
1143 1.19 fvdl /*
1144 1.19 fvdl * If ok, add it to the hash list for the mount point.
1145 1.19 fvdl */
1146 1.19 fvdl if (deltasec <= NFS_KERBCLOCKSKEW) {
1147 1.19 fvdl if (nmp->nm_numuids < nuidhash_max) {
1148 1.19 fvdl nmp->nm_numuids++;
1149 1.19 fvdl nuidp = (struct nfsuid *)
1150 1.19 fvdl malloc(sizeof (struct nfsuid), M_NFSUID,
1151 1.19 fvdl M_WAITOK);
1152 1.19 fvdl } else {
1153 1.19 fvdl nuidp = nmp->nm_uidlruhead.tqh_first;
1154 1.19 fvdl LIST_REMOVE(nuidp, nu_hash);
1155 1.19 fvdl TAILQ_REMOVE(&nmp->nm_uidlruhead, nuidp,
1156 1.19 fvdl nu_lru);
1157 1.19 fvdl }
1158 1.19 fvdl nuidp->nu_flag = 0;
1159 1.19 fvdl nuidp->nu_cr.cr_uid = cred->cr_uid;
1160 1.19 fvdl nuidp->nu_expire = time.tv_sec + NFS_KERBTTL;
1161 1.19 fvdl nuidp->nu_timestamp = ktvout;
1162 1.19 fvdl nuidp->nu_nickname = nick;
1163 1.32 perry memcpy(nuidp->nu_key, key, sizeof (key));
1164 1.19 fvdl TAILQ_INSERT_TAIL(&nmp->nm_uidlruhead, nuidp,
1165 1.19 fvdl nu_lru);
1166 1.19 fvdl LIST_INSERT_HEAD(NMUIDHASH(nmp, cred->cr_uid),
1167 1.19 fvdl nuidp, nu_hash);
1168 1.19 fvdl }
1169 1.19 fvdl } else
1170 1.19 fvdl nfsm_adv(nfsm_rndup(len));
1171 1.19 fvdl nfsmout:
1172 1.19 fvdl *mdp = md;
1173 1.19 fvdl *dposp = dpos;
1174 1.10 mycroft return (error);
1175 1.10 mycroft }
1176 1.24 thorpej #endif /* NFS */
1177