nfs_syscalls.c revision 1.124 1 1.124 yamt /* $NetBSD: nfs_syscalls.c,v 1.124 2007/08/10 15:12:56 yamt 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.70 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.19 fvdl * @(#)nfs_syscalls.c 8.5 (Berkeley) 3/30/95
35 1.1 cgd */
36 1.49 lukem
37 1.49 lukem #include <sys/cdefs.h>
38 1.124 yamt __KERNEL_RCSID(0, "$NetBSD: nfs_syscalls.c,v 1.124 2007/08/10 15:12:56 yamt Exp $");
39 1.28 thorpej
40 1.28 thorpej #include "fs_nfs.h"
41 1.43 bjh21 #include "opt_nfs.h"
42 1.30 thorpej #include "opt_nfsserver.h"
43 1.31 jonathan #include "opt_iso.h"
44 1.41 fvdl #include "opt_inet.h"
45 1.39 tsarna #include "opt_compat_netbsd.h"
46 1.1 cgd
47 1.7 mycroft #include <sys/param.h>
48 1.7 mycroft #include <sys/systm.h>
49 1.7 mycroft #include <sys/kernel.h>
50 1.7 mycroft #include <sys/file.h>
51 1.7 mycroft #include <sys/stat.h>
52 1.7 mycroft #include <sys/vnode.h>
53 1.7 mycroft #include <sys/mount.h>
54 1.7 mycroft #include <sys/proc.h>
55 1.10 mycroft #include <sys/uio.h>
56 1.7 mycroft #include <sys/malloc.h>
57 1.124 yamt #include <sys/kmem.h>
58 1.7 mycroft #include <sys/buf.h>
59 1.7 mycroft #include <sys/mbuf.h>
60 1.7 mycroft #include <sys/socket.h>
61 1.7 mycroft #include <sys/socketvar.h>
62 1.39 tsarna #include <sys/signalvar.h>
63 1.7 mycroft #include <sys/domain.h>
64 1.7 mycroft #include <sys/protosw.h>
65 1.10 mycroft #include <sys/namei.h>
66 1.10 mycroft #include <sys/syslog.h>
67 1.18 christos #include <sys/filedesc.h>
68 1.39 tsarna #include <sys/kthread.h>
69 1.92 elad #include <sys/kauth.h>
70 1.13 cgd #include <sys/syscallargs.h>
71 1.13 cgd
72 1.7 mycroft #include <netinet/in.h>
73 1.7 mycroft #include <netinet/tcp.h>
74 1.10 mycroft #ifdef ISO
75 1.10 mycroft #include <netiso/iso.h>
76 1.10 mycroft #endif
77 1.19 fvdl #include <nfs/xdr_subs.h>
78 1.10 mycroft #include <nfs/rpcv2.h>
79 1.19 fvdl #include <nfs/nfsproto.h>
80 1.7 mycroft #include <nfs/nfs.h>
81 1.19 fvdl #include <nfs/nfsm_subs.h>
82 1.7 mycroft #include <nfs/nfsrvcache.h>
83 1.10 mycroft #include <nfs/nfsmount.h>
84 1.10 mycroft #include <nfs/nfsnode.h>
85 1.10 mycroft #include <nfs/nfsrtt.h>
86 1.18 christos #include <nfs/nfs_var.h>
87 1.1 cgd
88 1.1 cgd /* Global defs. */
89 1.19 fvdl extern int32_t (*nfsrv3_procs[NFS_NPROCS]) __P((struct nfsrv_descript *,
90 1.19 fvdl struct nfssvc_sock *,
91 1.84 christos struct lwp *, struct mbuf **));
92 1.19 fvdl extern int nfsrvw_procrastinate;
93 1.51 matt
94 1.47 chs struct nfssvc_sock *nfs_udpsock;
95 1.47 chs #ifdef ISO
96 1.47 chs struct nfssvc_sock *nfs_cltpsock;
97 1.47 chs #endif
98 1.41 fvdl #ifdef INET6
99 1.41 fvdl struct nfssvc_sock *nfs_udp6sock;
100 1.41 fvdl #endif
101 1.10 mycroft int nuidhash_max = NFS_MAXUIDHASH;
102 1.18 christos #ifdef NFSSERVER
103 1.10 mycroft static int nfs_numnfsd = 0;
104 1.10 mycroft static struct nfsdrt nfsdrt;
105 1.18 christos #endif
106 1.51 matt
107 1.66 yamt #ifdef NFSSERVER
108 1.111 yamt kmutex_t nfsd_lock;
109 1.51 matt struct nfssvc_sockhead nfssvc_sockhead;
110 1.111 yamt kcondvar_t nfsd_initcv;
111 1.66 yamt struct nfssvc_sockhead nfssvc_sockpending;
112 1.51 matt struct nfsdhead nfsd_head;
113 1.66 yamt struct nfsdidlehead nfsd_idle_head;
114 1.51 matt
115 1.51 matt int nfssvc_sockhead_flag;
116 1.51 matt int nfsd_head_flag;
117 1.66 yamt #endif
118 1.1 cgd
119 1.54 thorpej MALLOC_DEFINE(M_NFSUID, "NFS uid", "Nfs uid mapping structure");
120 1.1 cgd
121 1.24 thorpej #ifdef NFS
122 1.124 yamt /*
123 1.124 yamt * locking order:
124 1.124 yamt * nfs_iodlist_lock -> nid_lock -> nm_lock
125 1.124 yamt */
126 1.123 yamt kmutex_t nfs_iodlist_lock;
127 1.124 yamt struct nfs_iodlist nfs_iodlist_idle;
128 1.124 yamt struct nfs_iodlist nfs_iodlist_all;
129 1.40 tsarna int nfs_niothreads = -1; /* == "0, and has never been set" */
130 1.23 thorpej #endif
131 1.19 fvdl
132 1.18 christos #ifdef NFSSERVER
133 1.65 yamt static struct nfssvc_sock *nfsrv_sockalloc __P((void));
134 1.77 yamt static void nfsrv_sockfree __P((struct nfssvc_sock *));
135 1.86 yamt static void nfsd_rt __P((int, struct nfsrv_descript *, int));
136 1.18 christos #endif
137 1.19 fvdl
138 1.1 cgd /*
139 1.1 cgd * NFS server system calls
140 1.1 cgd */
141 1.1 cgd
142 1.1 cgd
143 1.1 cgd /*
144 1.19 fvdl * Nfs server pseudo system call for the nfsd's
145 1.10 mycroft * Based on the flag value it either:
146 1.10 mycroft * - adds a socket to the selection list
147 1.10 mycroft * - remains in the kernel as an nfsd
148 1.10 mycroft * - remains in the kernel as an nfsiod
149 1.1 cgd */
150 1.18 christos int
151 1.99 yamt sys_nfssvc(struct lwp *l, void *v, register_t *retval)
152 1.15 thorpej {
153 1.38 augustss struct sys_nfssvc_args /* {
154 1.13 cgd syscallarg(int) flag;
155 1.107 christos syscallarg(void *) argp;
156 1.15 thorpej } */ *uap = v;
157 1.23 thorpej int error;
158 1.18 christos #ifdef NFSSERVER
159 1.1 cgd struct file *fp;
160 1.10 mycroft struct mbuf *nam;
161 1.10 mycroft struct nfsd_args nfsdarg;
162 1.10 mycroft struct nfsd_srvargs nfsd_srvargs, *nsd = &nfsd_srvargs;
163 1.10 mycroft struct nfsd *nfsd;
164 1.10 mycroft struct nfssvc_sock *slp;
165 1.18 christos struct nfsuid *nuidp;
166 1.18 christos #endif
167 1.1 cgd
168 1.1 cgd /*
169 1.1 cgd * Must be super user
170 1.1 cgd */
171 1.96 ad error = kauth_authorize_generic(l->l_cred, KAUTH_GENERIC_ISSUSER,
172 1.103 elad NULL);
173 1.71 thorpej if (error)
174 1.1 cgd return (error);
175 1.83 thorpej
176 1.83 thorpej /* Initialize NFS server / client shared data. */
177 1.83 thorpej nfs_init();
178 1.83 thorpej
179 1.67 yamt #ifdef NFSSERVER
180 1.111 yamt mutex_enter(&nfsd_lock);
181 1.12 mycroft while (nfssvc_sockhead_flag & SLP_INIT) {
182 1.111 yamt cv_wait(&nfsd_initcv, &nfsd_lock);
183 1.10 mycroft }
184 1.111 yamt mutex_exit(&nfsd_lock);
185 1.67 yamt #endif
186 1.13 cgd if (SCARG(uap, flag) & NFSSVC_BIOD) {
187 1.39 tsarna #if defined(NFS) && defined(COMPAT_14)
188 1.118 yamt error = kpause("nfsbiod", true, 0, NULL); /* dummy impl */
189 1.19 fvdl #else
190 1.10 mycroft error = ENOSYS;
191 1.19 fvdl #endif
192 1.13 cgd } else if (SCARG(uap, flag) & NFSSVC_MNTD) {
193 1.10 mycroft error = ENOSYS;
194 1.13 cgd } else if (SCARG(uap, flag) & NFSSVC_ADDSOCK) {
195 1.10 mycroft #ifndef NFSSERVER
196 1.10 mycroft error = ENOSYS;
197 1.19 fvdl #else
198 1.107 christos error = copyin(SCARG(uap, argp), (void *)&nfsdarg,
199 1.19 fvdl sizeof(nfsdarg));
200 1.18 christos if (error)
201 1.10 mycroft return (error);
202 1.35 thorpej /* getsock() will use the descriptor for us */
203 1.96 ad error = getsock(l->l_proc->p_fd, nfsdarg.sock, &fp);
204 1.19 fvdl if (error)
205 1.10 mycroft return (error);
206 1.10 mycroft /*
207 1.10 mycroft * Get the client address for connected sockets.
208 1.10 mycroft */
209 1.10 mycroft if (nfsdarg.name == NULL || nfsdarg.namelen == 0)
210 1.10 mycroft nam = (struct mbuf *)0;
211 1.18 christos else {
212 1.18 christos error = sockargs(&nam, nfsdarg.name, nfsdarg.namelen,
213 1.19 fvdl MT_SONAME);
214 1.35 thorpej if (error) {
215 1.35 thorpej FILE_UNUSE(fp, NULL);
216 1.18 christos return (error);
217 1.35 thorpej }
218 1.18 christos }
219 1.10 mycroft error = nfssvc_addsock(fp, nam);
220 1.35 thorpej FILE_UNUSE(fp, NULL);
221 1.10 mycroft #endif /* !NFSSERVER */
222 1.82 jmmv } else if (SCARG(uap, flag) & NFSSVC_SETEXPORTSLIST) {
223 1.82 jmmv #ifndef NFSSERVER
224 1.82 jmmv error = ENOSYS;
225 1.82 jmmv #else
226 1.82 jmmv struct export_args *args;
227 1.82 jmmv struct mountd_exports_list mel;
228 1.82 jmmv
229 1.82 jmmv error = copyin(SCARG(uap, argp), &mel, sizeof(mel));
230 1.82 jmmv if (error != 0)
231 1.82 jmmv return error;
232 1.82 jmmv
233 1.82 jmmv args = (struct export_args *)malloc(mel.mel_nexports *
234 1.82 jmmv sizeof(struct export_args), M_TEMP, M_WAITOK);
235 1.82 jmmv error = copyin(mel.mel_exports, args, mel.mel_nexports *
236 1.82 jmmv sizeof(struct export_args));
237 1.82 jmmv if (error != 0) {
238 1.82 jmmv free(args, M_TEMP);
239 1.82 jmmv return error;
240 1.82 jmmv }
241 1.82 jmmv mel.mel_exports = args;
242 1.82 jmmv
243 1.84 christos error = mountd_set_exports_list(&mel, l);
244 1.82 jmmv
245 1.82 jmmv free(args, M_TEMP);
246 1.82 jmmv #endif /* !NFSSERVER */
247 1.10 mycroft } else {
248 1.10 mycroft #ifndef NFSSERVER
249 1.10 mycroft error = ENOSYS;
250 1.19 fvdl #else
251 1.107 christos error = copyin(SCARG(uap, argp), (void *)nsd, sizeof (*nsd));
252 1.18 christos if (error)
253 1.10 mycroft return (error);
254 1.13 cgd if ((SCARG(uap, flag) & NFSSVC_AUTHIN) &&
255 1.19 fvdl ((nfsd = nsd->nsd_nfsd)) != NULL &&
256 1.19 fvdl (nfsd->nfsd_slp->ns_flag & SLP_VALID)) {
257 1.19 fvdl slp = nfsd->nfsd_slp;
258 1.10 mycroft
259 1.10 mycroft /*
260 1.10 mycroft * First check to see if another nfsd has already
261 1.10 mycroft * added this credential.
262 1.10 mycroft */
263 1.92 elad LIST_FOREACH(nuidp, NUIDHASH(slp, nsd->nsd_cr.cr_uid),
264 1.57 yamt nu_hash) {
265 1.93 yamt if (kauth_cred_geteuid(nuidp->nu_cr) ==
266 1.93 yamt nsd->nsd_cr.cr_uid &&
267 1.19 fvdl (!nfsd->nfsd_nd->nd_nam2 ||
268 1.19 fvdl netaddr_match(NU_NETFAM(nuidp),
269 1.19 fvdl &nuidp->nu_haddr, nfsd->nfsd_nd->nd_nam2)))
270 1.10 mycroft break;
271 1.10 mycroft }
272 1.19 fvdl if (nuidp) {
273 1.93 yamt kauth_cred_hold(nuidp->nu_cr);
274 1.93 yamt nfsd->nfsd_nd->nd_cr = nuidp->nu_cr;
275 1.19 fvdl nfsd->nfsd_nd->nd_flag |= ND_KERBFULL;
276 1.19 fvdl } else {
277 1.10 mycroft /*
278 1.10 mycroft * Nope, so we will.
279 1.10 mycroft */
280 1.10 mycroft if (slp->ns_numuids < nuidhash_max) {
281 1.10 mycroft slp->ns_numuids++;
282 1.10 mycroft nuidp = (struct nfsuid *)
283 1.10 mycroft malloc(sizeof (struct nfsuid), M_NFSUID,
284 1.10 mycroft M_WAITOK);
285 1.10 mycroft } else
286 1.10 mycroft nuidp = (struct nfsuid *)0;
287 1.10 mycroft if ((slp->ns_flag & SLP_VALID) == 0) {
288 1.10 mycroft if (nuidp)
289 1.107 christos free((void *)nuidp, M_NFSUID);
290 1.10 mycroft } else {
291 1.10 mycroft if (nuidp == (struct nfsuid *)0) {
292 1.57 yamt nuidp = TAILQ_FIRST(&slp->ns_uidlruhead);
293 1.12 mycroft LIST_REMOVE(nuidp, nu_hash);
294 1.12 mycroft TAILQ_REMOVE(&slp->ns_uidlruhead, nuidp,
295 1.12 mycroft nu_lru);
296 1.19 fvdl if (nuidp->nu_flag & NU_NAM)
297 1.19 fvdl m_freem(nuidp->nu_nam);
298 1.10 mycroft }
299 1.19 fvdl nuidp->nu_flag = 0;
300 1.98 pooka kauth_uucred_to_cred(nuidp->nu_cr,
301 1.98 pooka &nsd->nsd_cr);
302 1.19 fvdl nuidp->nu_timestamp = nsd->nsd_timestamp;
303 1.95 kardel nuidp->nu_expire = time_second + nsd->nsd_ttl;
304 1.19 fvdl /*
305 1.19 fvdl * and save the session key in nu_key.
306 1.19 fvdl */
307 1.32 perry memcpy(nuidp->nu_key, nsd->nsd_key,
308 1.32 perry sizeof(nsd->nsd_key));
309 1.19 fvdl if (nfsd->nfsd_nd->nd_nam2) {
310 1.19 fvdl struct sockaddr_in *saddr;
311 1.19 fvdl
312 1.19 fvdl saddr = mtod(nfsd->nfsd_nd->nd_nam2,
313 1.19 fvdl struct sockaddr_in *);
314 1.19 fvdl switch (saddr->sin_family) {
315 1.19 fvdl case AF_INET:
316 1.19 fvdl nuidp->nu_flag |= NU_INETADDR;
317 1.19 fvdl nuidp->nu_inetaddr =
318 1.19 fvdl saddr->sin_addr.s_addr;
319 1.19 fvdl break;
320 1.19 fvdl case AF_ISO:
321 1.19 fvdl default:
322 1.19 fvdl nuidp->nu_flag |= NU_NAM;
323 1.19 fvdl nuidp->nu_nam = m_copym(
324 1.19 fvdl nfsd->nfsd_nd->nd_nam2, 0,
325 1.19 fvdl M_COPYALL, M_WAIT);
326 1.19 fvdl break;
327 1.19 fvdl };
328 1.19 fvdl }
329 1.12 mycroft TAILQ_INSERT_TAIL(&slp->ns_uidlruhead, nuidp,
330 1.19 fvdl nu_lru);
331 1.12 mycroft LIST_INSERT_HEAD(NUIDHASH(slp, nsd->nsd_uid),
332 1.19 fvdl nuidp, nu_hash);
333 1.93 yamt kauth_cred_hold(nuidp->nu_cr);
334 1.93 yamt nfsd->nfsd_nd->nd_cr = nuidp->nu_cr;
335 1.19 fvdl nfsd->nfsd_nd->nd_flag |= ND_KERBFULL;
336 1.10 mycroft }
337 1.10 mycroft }
338 1.10 mycroft }
339 1.13 cgd if ((SCARG(uap, flag) & NFSSVC_AUTHINFAIL) &&
340 1.13 cgd (nfsd = nsd->nsd_nfsd))
341 1.19 fvdl nfsd->nfsd_flag |= NFSD_AUTHFAIL;
342 1.53 thorpej error = nfssvc_nfsd(nsd, SCARG(uap, argp), l);
343 1.10 mycroft #endif /* !NFSSERVER */
344 1.10 mycroft }
345 1.10 mycroft if (error == EINTR || error == ERESTART)
346 1.10 mycroft error = 0;
347 1.10 mycroft return (error);
348 1.10 mycroft }
349 1.10 mycroft
350 1.10 mycroft #ifdef NFSSERVER
351 1.54 thorpej MALLOC_DEFINE(M_NFSD, "NFS daemon", "Nfs server daemon structure");
352 1.54 thorpej MALLOC_DEFINE(M_NFSSVC, "NFS srvsock", "Nfs server structure");
353 1.54 thorpej
354 1.65 yamt static struct nfssvc_sock *
355 1.65 yamt nfsrv_sockalloc()
356 1.65 yamt {
357 1.65 yamt struct nfssvc_sock *slp;
358 1.78 perry
359 1.65 yamt slp = (struct nfssvc_sock *)
360 1.65 yamt malloc(sizeof (struct nfssvc_sock), M_NFSSVC, M_WAITOK);
361 1.65 yamt memset(slp, 0, sizeof (struct nfssvc_sock));
362 1.111 yamt mutex_init(&slp->ns_lock, MUTEX_DRIVER, IPL_SOFTNET);
363 1.111 yamt cv_init(&slp->ns_cv, "nfsdsock");
364 1.65 yamt TAILQ_INIT(&slp->ns_uidlruhead);
365 1.86 yamt LIST_INIT(&slp->ns_tq);
366 1.86 yamt SIMPLEQ_INIT(&slp->ns_sendq);
367 1.111 yamt mutex_enter(&nfsd_lock);
368 1.65 yamt TAILQ_INSERT_TAIL(&nfssvc_sockhead, slp, ns_chain);
369 1.111 yamt mutex_exit(&nfsd_lock);
370 1.65 yamt
371 1.65 yamt return slp;
372 1.65 yamt }
373 1.65 yamt
374 1.77 yamt static void
375 1.77 yamt nfsrv_sockfree(struct nfssvc_sock *slp)
376 1.77 yamt {
377 1.77 yamt
378 1.77 yamt KASSERT(slp->ns_so == NULL);
379 1.77 yamt KASSERT(slp->ns_fp == NULL);
380 1.85 yamt KASSERT((slp->ns_flag & SLP_VALID) == 0);
381 1.111 yamt mutex_destroy(&slp->ns_lock);
382 1.111 yamt cv_destroy(&slp->ns_cv);
383 1.77 yamt free(slp, M_NFSSVC);
384 1.77 yamt }
385 1.77 yamt
386 1.10 mycroft /*
387 1.10 mycroft * Adds a socket to the list for servicing by nfsds.
388 1.10 mycroft */
389 1.18 christos int
390 1.10 mycroft nfssvc_addsock(fp, mynam)
391 1.10 mycroft struct file *fp;
392 1.10 mycroft struct mbuf *mynam;
393 1.10 mycroft {
394 1.38 augustss struct mbuf *m;
395 1.38 augustss int siz;
396 1.38 augustss struct nfssvc_sock *slp;
397 1.38 augustss struct socket *so;
398 1.10 mycroft struct nfssvc_sock *tslp;
399 1.10 mycroft int error, s;
400 1.10 mycroft
401 1.1 cgd so = (struct socket *)fp->f_data;
402 1.10 mycroft tslp = (struct nfssvc_sock *)0;
403 1.10 mycroft /*
404 1.10 mycroft * Add it to the list, as required.
405 1.10 mycroft */
406 1.10 mycroft if (so->so_proto->pr_protocol == IPPROTO_UDP) {
407 1.41 fvdl #ifdef INET6
408 1.41 fvdl if (so->so_proto->pr_domain->dom_family == AF_INET6)
409 1.41 fvdl tslp = nfs_udp6sock;
410 1.41 fvdl else
411 1.41 fvdl #endif
412 1.10 mycroft tslp = nfs_udpsock;
413 1.10 mycroft if (tslp->ns_flag & SLP_VALID) {
414 1.10 mycroft m_freem(mynam);
415 1.10 mycroft return (EPERM);
416 1.10 mycroft }
417 1.10 mycroft #ifdef ISO
418 1.10 mycroft } else if (so->so_proto->pr_protocol == ISOPROTO_CLTP) {
419 1.10 mycroft tslp = nfs_cltpsock;
420 1.10 mycroft if (tslp->ns_flag & SLP_VALID) {
421 1.10 mycroft m_freem(mynam);
422 1.10 mycroft return (EPERM);
423 1.10 mycroft }
424 1.10 mycroft #endif /* ISO */
425 1.10 mycroft }
426 1.10 mycroft if (so->so_type == SOCK_STREAM)
427 1.19 fvdl siz = NFS_MAXPACKET + sizeof (u_long);
428 1.10 mycroft else
429 1.1 cgd siz = NFS_MAXPACKET;
430 1.78 perry error = soreserve(so, siz, siz);
431 1.19 fvdl if (error) {
432 1.10 mycroft m_freem(mynam);
433 1.10 mycroft return (error);
434 1.10 mycroft }
435 1.1 cgd
436 1.1 cgd /*
437 1.1 cgd * Set protocol specific options { for now TCP only } and
438 1.1 cgd * reserve some space. For datagram sockets, this can get called
439 1.1 cgd * repeatedly for the same socket, but that isn't harmful.
440 1.1 cgd */
441 1.10 mycroft if (so->so_type == SOCK_STREAM) {
442 1.55 matt m = m_get(M_WAIT, MT_SOOPTS);
443 1.55 matt MCLAIM(m, &nfs_mowner);
444 1.19 fvdl *mtod(m, int32_t *) = 1;
445 1.19 fvdl m->m_len = sizeof(int32_t);
446 1.1 cgd sosetopt(so, SOL_SOCKET, SO_KEEPALIVE, m);
447 1.1 cgd }
448 1.41 fvdl if ((so->so_proto->pr_domain->dom_family == AF_INET
449 1.41 fvdl #ifdef INET6
450 1.41 fvdl || so->so_proto->pr_domain->dom_family == AF_INET6
451 1.41 fvdl #endif
452 1.41 fvdl ) &&
453 1.10 mycroft so->so_proto->pr_protocol == IPPROTO_TCP) {
454 1.55 matt m = m_get(M_WAIT, MT_SOOPTS);
455 1.55 matt MCLAIM(m, &nfs_mowner);
456 1.19 fvdl *mtod(m, int32_t *) = 1;
457 1.19 fvdl m->m_len = sizeof(int32_t);
458 1.1 cgd sosetopt(so, IPPROTO_TCP, TCP_NODELAY, m);
459 1.1 cgd }
460 1.1 cgd so->so_rcv.sb_flags &= ~SB_NOINTR;
461 1.1 cgd so->so_rcv.sb_timeo = 0;
462 1.1 cgd so->so_snd.sb_flags &= ~SB_NOINTR;
463 1.1 cgd so->so_snd.sb_timeo = 0;
464 1.111 yamt if (tslp) {
465 1.10 mycroft slp = tslp;
466 1.111 yamt } else {
467 1.65 yamt slp = nfsrv_sockalloc();
468 1.10 mycroft }
469 1.10 mycroft slp->ns_so = so;
470 1.10 mycroft slp->ns_nam = mynam;
471 1.10 mycroft fp->f_count++;
472 1.10 mycroft slp->ns_fp = fp;
473 1.14 mycroft s = splsoftnet();
474 1.107 christos so->so_upcallarg = (void *)slp;
475 1.10 mycroft so->so_upcall = nfsrv_rcv;
476 1.29 matt so->so_rcv.sb_flags |= SB_UPCALL;
477 1.111 yamt slp->ns_flag = SLP_VALID | SLP_NEEDQ;
478 1.10 mycroft nfsrv_wakenfsd(slp);
479 1.10 mycroft splx(s);
480 1.10 mycroft return (0);
481 1.10 mycroft }
482 1.1 cgd
483 1.10 mycroft /*
484 1.10 mycroft * Called by nfssvc() for nfsds. Just loops around servicing rpc requests
485 1.10 mycroft * until it is killed by a signal.
486 1.10 mycroft */
487 1.18 christos int
488 1.53 thorpej nfssvc_nfsd(nsd, argp, l)
489 1.10 mycroft struct nfsd_srvargs *nsd;
490 1.107 christos void *argp;
491 1.53 thorpej struct lwp *l;
492 1.10 mycroft {
493 1.95 kardel struct timeval tv;
494 1.38 augustss struct mbuf *m;
495 1.38 augustss struct nfssvc_sock *slp;
496 1.19 fvdl struct nfsd *nfsd = nsd->nsd_nfsd;
497 1.19 fvdl struct nfsrv_descript *nd = NULL;
498 1.19 fvdl struct mbuf *mreq;
499 1.19 fvdl u_quad_t cur_usec;
500 1.111 yamt int error = 0, cacherep, siz, sotype, writes_todo;
501 1.53 thorpej struct proc *p = l->l_proc;
502 1.111 yamt int s;
503 1.19 fvdl
504 1.19 fvdl #ifndef nolint
505 1.19 fvdl cacherep = RC_DOIT;
506 1.19 fvdl writes_todo = 0;
507 1.19 fvdl #endif
508 1.117 ad uvm_lwp_hold(l);
509 1.111 yamt if (nfsd == NULL) {
510 1.111 yamt nsd->nsd_nfsd = nfsd =
511 1.10 mycroft malloc(sizeof (struct nfsd), M_NFSD, M_WAITOK);
512 1.111 yamt memset(nfsd, 0, sizeof (struct nfsd));
513 1.111 yamt cv_init(&nfsd->nfsd_cv, "nfsd");
514 1.19 fvdl nfsd->nfsd_procp = p;
515 1.111 yamt mutex_enter(&nfsd_lock);
516 1.19 fvdl TAILQ_INSERT_TAIL(&nfsd_head, nfsd, nfsd_chain);
517 1.10 mycroft nfs_numnfsd++;
518 1.111 yamt mutex_exit(&nfsd_lock);
519 1.10 mycroft }
520 1.1 cgd /*
521 1.10 mycroft * Loop getting rpc requests until SIGKILL.
522 1.1 cgd */
523 1.1 cgd for (;;) {
524 1.113 yamt if ((curcpu()->ci_schedstate.spc_flags & SPCF_SHOULDYIELD)
525 1.113 yamt != 0) {
526 1.113 yamt preempt();
527 1.113 yamt }
528 1.85 yamt if (nfsd->nfsd_slp == NULL) {
529 1.111 yamt mutex_enter(&nfsd_lock);
530 1.85 yamt while (nfsd->nfsd_slp == NULL &&
531 1.12 mycroft (nfsd_head_flag & NFSD_CHECKSLP) == 0) {
532 1.66 yamt SLIST_INSERT_HEAD(&nfsd_idle_head, nfsd,
533 1.66 yamt nfsd_idle);
534 1.111 yamt error = cv_wait_sig(&nfsd->nfsd_cv, &nfsd_lock);
535 1.66 yamt if (error) {
536 1.66 yamt slp = nfsd->nfsd_slp;
537 1.66 yamt nfsd->nfsd_slp = NULL;
538 1.66 yamt if (!slp)
539 1.66 yamt SLIST_REMOVE(&nfsd_idle_head,
540 1.66 yamt nfsd, nfsd, nfsd_idle);
541 1.111 yamt mutex_exit(&nfsd_lock);
542 1.66 yamt if (slp) {
543 1.66 yamt nfsrv_wakenfsd(slp);
544 1.66 yamt nfsrv_slpderef(slp);
545 1.66 yamt }
546 1.10 mycroft goto done;
547 1.66 yamt }
548 1.112 yamt KASSERT(nfsd->nfsd_slp != NULL);
549 1.10 mycroft }
550 1.85 yamt if (nfsd->nfsd_slp == NULL &&
551 1.12 mycroft (nfsd_head_flag & NFSD_CHECKSLP) != 0) {
552 1.66 yamt slp = TAILQ_FIRST(&nfssvc_sockpending);
553 1.66 yamt if (slp) {
554 1.121 yamt KASSERT((slp->ns_flag & SLP_DOREC)
555 1.121 yamt != 0);
556 1.66 yamt TAILQ_REMOVE(&nfssvc_sockpending, slp,
557 1.66 yamt ns_pending);
558 1.66 yamt slp->ns_flag &= ~SLP_DOREC;
559 1.66 yamt slp->ns_sref++;
560 1.66 yamt nfsd->nfsd_slp = slp;
561 1.66 yamt } else
562 1.12 mycroft nfsd_head_flag &= ~NFSD_CHECKSLP;
563 1.10 mycroft }
564 1.116 yamt KASSERT(nfsd->nfsd_slp == NULL ||
565 1.116 yamt nfsd->nfsd_slp->ns_sref > 0);
566 1.111 yamt mutex_exit(&nfsd_lock);
567 1.85 yamt if ((slp = nfsd->nfsd_slp) == NULL)
568 1.10 mycroft continue;
569 1.116 yamt KASSERT(slp->ns_sref > 0);
570 1.10 mycroft if (slp->ns_flag & SLP_VALID) {
571 1.119 yamt if ((slp->ns_flag & SLP_NEEDQ) != 0) {
572 1.85 yamt nfsrv_rcv(slp->ns_so, (void *)slp,
573 1.85 yamt M_WAIT);
574 1.10 mycroft }
575 1.119 yamt if ((slp->ns_flag & SLP_DISCONN) != 0) {
576 1.119 yamt nfsrv_zapsock(slp);
577 1.119 yamt }
578 1.19 fvdl error = nfsrv_dorec(slp, nfsd, &nd);
579 1.95 kardel getmicrotime(&tv);
580 1.95 kardel cur_usec = (u_quad_t)tv.tv_sec * 1000000 +
581 1.95 kardel (u_quad_t)tv.tv_usec;
582 1.57 yamt if (error && LIST_FIRST(&slp->ns_tq) &&
583 1.57 yamt LIST_FIRST(&slp->ns_tq)->nd_time <=
584 1.57 yamt cur_usec) {
585 1.19 fvdl error = 0;
586 1.19 fvdl cacherep = RC_DOIT;
587 1.19 fvdl writes_todo = 1;
588 1.19 fvdl } else
589 1.19 fvdl writes_todo = 0;
590 1.85 yamt if (error == 0 && slp->ns_rec != NULL) {
591 1.85 yamt nfsrv_wakenfsd(slp);
592 1.85 yamt }
593 1.1 cgd }
594 1.10 mycroft } else {
595 1.10 mycroft error = 0;
596 1.19 fvdl slp = nfsd->nfsd_slp;
597 1.10 mycroft }
598 1.116 yamt KASSERT(slp != NULL);
599 1.116 yamt KASSERT(nfsd->nfsd_slp == slp);
600 1.10 mycroft if (error || (slp->ns_flag & SLP_VALID) == 0) {
601 1.19 fvdl if (nd) {
602 1.93 yamt nfsdreq_free(nd);
603 1.19 fvdl nd = NULL;
604 1.19 fvdl }
605 1.85 yamt nfsd->nfsd_slp = NULL;
606 1.10 mycroft nfsrv_slpderef(slp);
607 1.1 cgd continue;
608 1.1 cgd }
609 1.86 yamt sotype = slp->ns_so->so_type;
610 1.19 fvdl if (nd) {
611 1.95 kardel getmicrotime(&nd->nd_starttime);
612 1.63 yamt if (nd->nd_nam2)
613 1.63 yamt nd->nd_nam = nd->nd_nam2;
614 1.63 yamt else
615 1.63 yamt nd->nd_nam = slp->ns_nam;
616 1.63 yamt
617 1.63 yamt /*
618 1.63 yamt * Check to see if authorization is needed.
619 1.63 yamt */
620 1.63 yamt if (nfsd->nfsd_flag & NFSD_NEEDAUTH) {
621 1.63 yamt nfsd->nfsd_flag &= ~NFSD_NEEDAUTH;
622 1.63 yamt nsd->nsd_haddr = mtod(nd->nd_nam,
623 1.63 yamt struct sockaddr_in *)->sin_addr.s_addr;
624 1.63 yamt nsd->nsd_authlen = nfsd->nfsd_authlen;
625 1.63 yamt nsd->nsd_verflen = nfsd->nfsd_verflen;
626 1.63 yamt if (!copyout(nfsd->nfsd_authstr,
627 1.63 yamt nsd->nsd_authstr, nfsd->nfsd_authlen) &&
628 1.63 yamt !copyout(nfsd->nfsd_verfstr,
629 1.63 yamt nsd->nsd_verfstr, nfsd->nfsd_verflen) &&
630 1.63 yamt !copyout(nsd, argp, sizeof (*nsd))) {
631 1.117 ad uvm_lwp_rele(l);
632 1.63 yamt return (ENEEDAUTH);
633 1.63 yamt }
634 1.63 yamt cacherep = RC_DROPIT;
635 1.10 mycroft } else
636 1.63 yamt cacherep = nfsrv_getcache(nd, slp, &mreq);
637 1.63 yamt
638 1.100 yamt if (nfsd->nfsd_flag & NFSD_AUTHFAIL) {
639 1.63 yamt nfsd->nfsd_flag &= ~NFSD_AUTHFAIL;
640 1.10 mycroft nd->nd_procnum = NFSPROC_NOOP;
641 1.63 yamt nd->nd_repstat =
642 1.63 yamt (NFSERR_AUTHERR | AUTH_TOOWEAK);
643 1.10 mycroft cacherep = RC_DOIT;
644 1.63 yamt }
645 1.10 mycroft }
646 1.10 mycroft
647 1.19 fvdl /*
648 1.19 fvdl * Loop to get all the write rpc relies that have been
649 1.19 fvdl * gathered together.
650 1.19 fvdl */
651 1.19 fvdl do {
652 1.34 sommerfe #ifdef DIAGNOSTIC
653 1.63 yamt int lockcount;
654 1.34 sommerfe #endif
655 1.63 yamt switch (cacherep) {
656 1.63 yamt case RC_DOIT:
657 1.34 sommerfe #ifdef DIAGNOSTIC
658 1.63 yamt /*
659 1.63 yamt * NFS server procs should neither release
660 1.63 yamt * locks already held, nor leave things
661 1.63 yamt * locked. Catch this sooner, rather than
662 1.63 yamt * later (when we try to relock something we
663 1.63 yamt * already have locked). Careful inspection
664 1.63 yamt * of the failing routine usually turns up the
665 1.63 yamt * lock leak.. once we know what it is..
666 1.63 yamt */
667 1.63 yamt lockcount = l->l_locks;
668 1.34 sommerfe #endif
669 1.80 onoe mreq = NULL;
670 1.88 yamt netexport_rdlock();
671 1.90 christos if (writes_todo || nd == NULL ||
672 1.90 christos (!(nd->nd_flag & ND_NFSV3) &&
673 1.63 yamt nd->nd_procnum == NFSPROC_WRITE &&
674 1.100 yamt nfsrvw_procrastinate > 0))
675 1.63 yamt error = nfsrv_writegather(&nd, slp,
676 1.84 christos l, &mreq);
677 1.63 yamt else
678 1.63 yamt error =
679 1.63 yamt (*(nfsrv3_procs[nd->nd_procnum]))
680 1.84 christos (nd, slp, l, &mreq);
681 1.88 yamt netexport_rdunlock();
682 1.34 sommerfe #ifdef DIAGNOSTIC
683 1.63 yamt if (l->l_locks != lockcount) {
684 1.63 yamt /*
685 1.63 yamt * If you see this panic, audit
686 1.63 yamt * nfsrv3_procs[nd->nd_procnum] for
687 1.63 yamt * vnode locking errors (usually, it's
688 1.63 yamt * due to forgetting to vput()
689 1.63 yamt * something).
690 1.63 yamt */
691 1.46 matt #ifdef DEBUG
692 1.63 yamt extern void printlockedvnodes(void);
693 1.63 yamt printlockedvnodes();
694 1.46 matt #endif
695 1.63 yamt printf("nfsd: locking botch in op %d"
696 1.63 yamt " (before %d, after %d)\n",
697 1.63 yamt nd ? nd->nd_procnum : -1,
698 1.63 yamt lockcount, l->l_locks);
699 1.63 yamt }
700 1.34 sommerfe #endif
701 1.80 onoe if (mreq == NULL) {
702 1.80 onoe if (nd != NULL) {
703 1.80 onoe if (nd->nd_nam2)
704 1.80 onoe m_free(nd->nd_nam2);
705 1.80 onoe if (nd->nd_mrep)
706 1.80 onoe m_freem(nd->nd_mrep);
707 1.80 onoe }
708 1.63 yamt break;
709 1.80 onoe }
710 1.63 yamt if (error) {
711 1.100 yamt nfsstats.srv_errs++;
712 1.106 thorpej nfsrv_updatecache(nd, false, mreq);
713 1.63 yamt if (nd->nd_nam2)
714 1.63 yamt m_freem(nd->nd_nam2);
715 1.63 yamt break;
716 1.63 yamt }
717 1.63 yamt nfsstats.srvrpccnt[nd->nd_procnum]++;
718 1.106 thorpej nfsrv_updatecache(nd, true, mreq);
719 1.63 yamt nd->nd_mrep = (struct mbuf *)0;
720 1.63 yamt case RC_REPLY:
721 1.63 yamt m = mreq;
722 1.63 yamt siz = 0;
723 1.63 yamt while (m) {
724 1.63 yamt siz += m->m_len;
725 1.63 yamt m = m->m_next;
726 1.63 yamt }
727 1.63 yamt if (siz <= 0 || siz > NFS_MAXPACKET) {
728 1.63 yamt printf("mbuf siz=%d\n",siz);
729 1.63 yamt panic("Bad nfs svc reply");
730 1.63 yamt }
731 1.63 yamt m = mreq;
732 1.63 yamt m->m_pkthdr.len = siz;
733 1.63 yamt m->m_pkthdr.rcvif = (struct ifnet *)0;
734 1.63 yamt /*
735 1.63 yamt * For stream protocols, prepend a Sun RPC
736 1.63 yamt * Record Mark.
737 1.63 yamt */
738 1.63 yamt if (sotype == SOCK_STREAM) {
739 1.63 yamt M_PREPEND(m, NFSX_UNSIGNED, M_WAIT);
740 1.63 yamt *mtod(m, u_int32_t *) =
741 1.63 yamt htonl(0x80000000 | siz);
742 1.63 yamt }
743 1.86 yamt nd->nd_mreq = m;
744 1.86 yamt if (nfsrtton) {
745 1.86 yamt nfsd_rt(slp->ns_so->so_type, nd,
746 1.86 yamt cacherep);
747 1.63 yamt }
748 1.86 yamt error = nfsdsock_sendreply(slp, nd);
749 1.86 yamt nd = NULL;
750 1.63 yamt if (error == EPIPE)
751 1.63 yamt nfsrv_zapsock(slp);
752 1.63 yamt if (error == EINTR || error == ERESTART) {
753 1.114 yamt nfsd->nfsd_slp = NULL;
754 1.63 yamt nfsrv_slpderef(slp);
755 1.63 yamt goto done;
756 1.63 yamt }
757 1.19 fvdl break;
758 1.63 yamt case RC_DROPIT:
759 1.63 yamt if (nfsrtton)
760 1.63 yamt nfsd_rt(sotype, nd, cacherep);
761 1.63 yamt m_freem(nd->nd_mrep);
762 1.63 yamt m_freem(nd->nd_nam2);
763 1.1 cgd break;
764 1.1 cgd }
765 1.63 yamt if (nd) {
766 1.93 yamt nfsdreq_free(nd);
767 1.63 yamt nd = NULL;
768 1.63 yamt }
769 1.63 yamt
770 1.1 cgd /*
771 1.63 yamt * Check to see if there are outstanding writes that
772 1.63 yamt * need to be serviced.
773 1.1 cgd */
774 1.95 kardel getmicrotime(&tv);
775 1.95 kardel cur_usec = (u_quad_t)tv.tv_sec * 1000000 +
776 1.95 kardel (u_quad_t)tv.tv_usec;
777 1.63 yamt s = splsoftclock();
778 1.63 yamt if (LIST_FIRST(&slp->ns_tq) &&
779 1.63 yamt LIST_FIRST(&slp->ns_tq)->nd_time <= cur_usec) {
780 1.63 yamt cacherep = RC_DOIT;
781 1.63 yamt writes_todo = 1;
782 1.63 yamt } else
783 1.63 yamt writes_todo = 0;
784 1.63 yamt splx(s);
785 1.19 fvdl } while (writes_todo);
786 1.19 fvdl if (nfsrv_dorec(slp, nfsd, &nd)) {
787 1.19 fvdl nfsd->nfsd_slp = NULL;
788 1.10 mycroft nfsrv_slpderef(slp);
789 1.10 mycroft }
790 1.1 cgd }
791 1.10 mycroft done:
792 1.111 yamt mutex_enter(&nfsd_lock);
793 1.19 fvdl TAILQ_REMOVE(&nfsd_head, nfsd, nfsd_chain);
794 1.111 yamt mutex_exit(&nfsd_lock);
795 1.111 yamt cv_destroy(&nfsd->nfsd_cv);
796 1.111 yamt free(nfsd, M_NFSD);
797 1.111 yamt nsd->nsd_nfsd = NULL;
798 1.10 mycroft if (--nfs_numnfsd == 0)
799 1.106 thorpej nfsrv_init(true); /* Reinitialize everything */
800 1.117 ad uvm_lwp_rele(l);
801 1.1 cgd return (error);
802 1.1 cgd }
803 1.1 cgd
804 1.10 mycroft /*
805 1.10 mycroft * Shut down a socket associated with an nfssvc_sock structure.
806 1.10 mycroft * Should be called with the send lock set, if required.
807 1.10 mycroft * The trick here is to increment the sref at the start, so that the nfsds
808 1.10 mycroft * will stop using it and clear ns_flag at the end so that it will not be
809 1.10 mycroft * reassigned during cleanup.
810 1.73 yamt *
811 1.73 yamt * called at splsoftnet.
812 1.10 mycroft */
813 1.18 christos void
814 1.10 mycroft nfsrv_zapsock(slp)
815 1.38 augustss struct nfssvc_sock *slp;
816 1.10 mycroft {
817 1.38 augustss struct nfsuid *nuidp, *nnuidp;
818 1.38 augustss struct nfsrv_descript *nwp, *nnwp;
819 1.10 mycroft struct socket *so;
820 1.104 yamt struct mbuf *m;
821 1.19 fvdl int s;
822 1.10 mycroft
823 1.85 yamt if (nfsdsock_drain(slp)) {
824 1.74 yamt return;
825 1.74 yamt }
826 1.111 yamt mutex_enter(&nfsd_lock);
827 1.73 yamt if (slp->ns_flag & SLP_DOREC) {
828 1.73 yamt TAILQ_REMOVE(&nfssvc_sockpending, slp, ns_pending);
829 1.120 yamt slp->ns_flag &= ~SLP_DOREC;
830 1.73 yamt }
831 1.111 yamt mutex_exit(&nfsd_lock);
832 1.77 yamt
833 1.77 yamt so = slp->ns_so;
834 1.77 yamt KASSERT(so != NULL);
835 1.77 yamt so->so_upcall = NULL;
836 1.77 yamt so->so_upcallarg = NULL;
837 1.77 yamt so->so_rcv.sb_flags &= ~SB_UPCALL;
838 1.77 yamt soshutdown(so, SHUT_RDWR);
839 1.77 yamt
840 1.77 yamt if (slp->ns_nam)
841 1.77 yamt m_free(slp->ns_nam);
842 1.77 yamt m_freem(slp->ns_raw);
843 1.104 yamt m = slp->ns_rec;
844 1.104 yamt while (m != NULL) {
845 1.104 yamt struct mbuf *n;
846 1.104 yamt
847 1.104 yamt n = m->m_nextpkt;
848 1.104 yamt m_freem(m);
849 1.104 yamt m = n;
850 1.104 yamt }
851 1.77 yamt for (nuidp = TAILQ_FIRST(&slp->ns_uidlruhead); nuidp != 0;
852 1.77 yamt nuidp = nnuidp) {
853 1.77 yamt nnuidp = TAILQ_NEXT(nuidp, nu_lru);
854 1.77 yamt LIST_REMOVE(nuidp, nu_hash);
855 1.77 yamt TAILQ_REMOVE(&slp->ns_uidlruhead, nuidp, nu_lru);
856 1.77 yamt if (nuidp->nu_flag & NU_NAM)
857 1.77 yamt m_freem(nuidp->nu_nam);
858 1.107 christos free((void *)nuidp, M_NFSUID);
859 1.77 yamt }
860 1.77 yamt s = splsoftclock();
861 1.77 yamt for (nwp = LIST_FIRST(&slp->ns_tq); nwp; nwp = nnwp) {
862 1.77 yamt nnwp = LIST_NEXT(nwp, nd_tq);
863 1.77 yamt LIST_REMOVE(nwp, nd_tq);
864 1.93 yamt nfsdreq_free(nwp);
865 1.10 mycroft }
866 1.77 yamt splx(s);
867 1.10 mycroft }
868 1.10 mycroft
869 1.10 mycroft /*
870 1.10 mycroft * Derefence a server socket structure. If it has no more references and
871 1.10 mycroft * is no longer valid, you can throw it away.
872 1.10 mycroft */
873 1.10 mycroft void
874 1.10 mycroft nfsrv_slpderef(slp)
875 1.38 augustss struct nfssvc_sock *slp;
876 1.10 mycroft {
877 1.116 yamt uint32_t ref;
878 1.66 yamt
879 1.116 yamt mutex_enter(&nfsd_lock);
880 1.116 yamt KASSERT(slp->ns_sref > 0);
881 1.116 yamt ref = --slp->ns_sref;
882 1.116 yamt mutex_exit(&nfsd_lock);
883 1.116 yamt if (ref == 0 && (slp->ns_flag & SLP_VALID) == 0) {
884 1.85 yamt struct file *fp;
885 1.111 yamt
886 1.111 yamt mutex_enter(&nfsd_lock);
887 1.122 yamt KASSERT((slp->ns_flag & SLP_DOREC) == 0);
888 1.12 mycroft TAILQ_REMOVE(&nfssvc_sockhead, slp, ns_chain);
889 1.111 yamt mutex_exit(&nfsd_lock);
890 1.85 yamt
891 1.85 yamt fp = slp->ns_fp;
892 1.85 yamt if (fp != NULL) {
893 1.85 yamt slp->ns_fp = NULL;
894 1.85 yamt KASSERT(fp != NULL);
895 1.85 yamt KASSERT(fp->f_data == slp->ns_so);
896 1.85 yamt simple_lock(&fp->f_slock);
897 1.85 yamt FILE_USE(fp);
898 1.85 yamt closef(fp, (struct lwp *)0);
899 1.85 yamt slp->ns_so = NULL;
900 1.85 yamt }
901 1.85 yamt
902 1.77 yamt nfsrv_sockfree(slp);
903 1.10 mycroft }
904 1.10 mycroft }
905 1.10 mycroft
906 1.10 mycroft /*
907 1.10 mycroft * Initialize the data structures for the server.
908 1.10 mycroft * Handshake with any new nfsds starting up to avoid any chance of
909 1.10 mycroft * corruption.
910 1.10 mycroft */
911 1.10 mycroft void
912 1.10 mycroft nfsrv_init(terminating)
913 1.10 mycroft int terminating;
914 1.10 mycroft {
915 1.66 yamt struct nfssvc_sock *slp;
916 1.10 mycroft
917 1.111 yamt if (!terminating) {
918 1.111 yamt mutex_init(&nfsd_lock, MUTEX_DRIVER, IPL_SOFTNET);
919 1.111 yamt cv_init(&nfsd_initcv, "nfsdinit");
920 1.111 yamt }
921 1.111 yamt
922 1.111 yamt mutex_enter(&nfsd_lock);
923 1.12 mycroft if (nfssvc_sockhead_flag & SLP_INIT)
924 1.10 mycroft panic("nfsd init");
925 1.12 mycroft nfssvc_sockhead_flag |= SLP_INIT;
926 1.66 yamt
927 1.10 mycroft if (terminating) {
928 1.114 yamt KASSERT(SLIST_EMPTY(&nfsd_idle_head));
929 1.114 yamt KASSERT(TAILQ_EMPTY(&nfsd_head));
930 1.66 yamt while ((slp = TAILQ_FIRST(&nfssvc_sockhead)) != NULL) {
931 1.111 yamt mutex_exit(&nfsd_lock);
932 1.85 yamt KASSERT(slp->ns_sref == 0);
933 1.85 yamt slp->ns_sref++;
934 1.85 yamt nfsrv_zapsock(slp);
935 1.85 yamt nfsrv_slpderef(slp);
936 1.111 yamt mutex_enter(&nfsd_lock);
937 1.10 mycroft }
938 1.114 yamt KASSERT(TAILQ_EMPTY(&nfssvc_sockpending));
939 1.111 yamt mutex_exit(&nfsd_lock);
940 1.10 mycroft nfsrv_cleancache(); /* And clear out server cache */
941 1.66 yamt } else {
942 1.111 yamt mutex_exit(&nfsd_lock);
943 1.26 fvdl nfs_pub.np_valid = 0;
944 1.66 yamt }
945 1.12 mycroft
946 1.12 mycroft TAILQ_INIT(&nfssvc_sockhead);
947 1.66 yamt TAILQ_INIT(&nfssvc_sockpending);
948 1.12 mycroft
949 1.12 mycroft TAILQ_INIT(&nfsd_head);
950 1.66 yamt SLIST_INIT(&nfsd_idle_head);
951 1.12 mycroft nfsd_head_flag &= ~NFSD_CHECKSLP;
952 1.12 mycroft
953 1.65 yamt nfs_udpsock = nfsrv_sockalloc();
954 1.41 fvdl
955 1.41 fvdl #ifdef INET6
956 1.65 yamt nfs_udp6sock = nfsrv_sockalloc();
957 1.41 fvdl #endif
958 1.12 mycroft
959 1.47 chs #ifdef ISO
960 1.65 yamt nfs_cltpsock = nfsrv_sockalloc();
961 1.47 chs #endif
962 1.66 yamt
963 1.111 yamt mutex_enter(&nfsd_lock);
964 1.111 yamt nfssvc_sockhead_flag &= ~SLP_INIT;
965 1.111 yamt cv_broadcast(&nfsd_initcv);
966 1.111 yamt mutex_exit(&nfsd_lock);
967 1.10 mycroft }
968 1.10 mycroft
969 1.10 mycroft /*
970 1.10 mycroft * Add entries to the server monitor log.
971 1.10 mycroft */
972 1.10 mycroft static void
973 1.19 fvdl nfsd_rt(sotype, nd, cacherep)
974 1.10 mycroft int sotype;
975 1.38 augustss struct nfsrv_descript *nd;
976 1.10 mycroft int cacherep;
977 1.10 mycroft {
978 1.95 kardel struct timeval tv;
979 1.38 augustss struct drt *rt;
980 1.10 mycroft
981 1.10 mycroft rt = &nfsdrt.drt[nfsdrt.pos];
982 1.10 mycroft if (cacherep == RC_DOIT)
983 1.10 mycroft rt->flag = 0;
984 1.10 mycroft else if (cacherep == RC_REPLY)
985 1.10 mycroft rt->flag = DRT_CACHEREPLY;
986 1.10 mycroft else
987 1.10 mycroft rt->flag = DRT_CACHEDROP;
988 1.10 mycroft if (sotype == SOCK_STREAM)
989 1.10 mycroft rt->flag |= DRT_TCP;
990 1.102 yamt if (nd->nd_flag & ND_NFSV3)
991 1.19 fvdl rt->flag |= DRT_NFSV3;
992 1.10 mycroft rt->proc = nd->nd_procnum;
993 1.19 fvdl if (mtod(nd->nd_nam, struct sockaddr *)->sa_family == AF_INET)
994 1.19 fvdl rt->ipadr = mtod(nd->nd_nam, struct sockaddr_in *)->sin_addr.s_addr;
995 1.10 mycroft else
996 1.19 fvdl rt->ipadr = INADDR_ANY;
997 1.95 kardel getmicrotime(&tv);
998 1.95 kardel rt->resptime = ((tv.tv_sec - nd->nd_starttime.tv_sec) * 1000000) +
999 1.95 kardel (tv.tv_usec - nd->nd_starttime.tv_usec);
1000 1.95 kardel rt->tstamp = tv;
1001 1.10 mycroft nfsdrt.pos = (nfsdrt.pos + 1) % NFSRTTLOGSIZ;
1002 1.10 mycroft }
1003 1.3 glass #endif /* NFSSERVER */
1004 1.3 glass
1005 1.24 thorpej #ifdef NFS
1006 1.22 thorpej
1007 1.22 thorpej int nfs_defect = 0;
1008 1.1 cgd /*
1009 1.39 tsarna * Asynchronous I/O threads for client nfs.
1010 1.10 mycroft * They do read-ahead and write-behind operations on the block I/O cache.
1011 1.10 mycroft * Never returns unless it fails or gets killed.
1012 1.1 cgd */
1013 1.39 tsarna
1014 1.118 yamt static void
1015 1.118 yamt nfssvc_iod(void *arg)
1016 1.1 cgd {
1017 1.38 augustss struct buf *bp;
1018 1.58 yamt struct nfs_iod *myiod;
1019 1.22 thorpej struct nfsmount *nmp;
1020 1.1 cgd
1021 1.124 yamt KERNEL_LOCK(1, curlwp);
1022 1.124 yamt myiod = kmem_alloc(sizeof(*myiod), KM_SLEEP);
1023 1.124 yamt mutex_init(&myiod->nid_lock, MUTEX_DEFAULT, IPL_NONE);
1024 1.124 yamt KERNEL_UNLOCK_LAST(curlwp);
1025 1.124 yamt cv_init(&myiod->nid_cv, "nfsiod");
1026 1.124 yamt myiod->nid_exiting = false;
1027 1.124 yamt myiod->nid_mount = NULL;
1028 1.123 yamt mutex_enter(&nfs_iodlist_lock);
1029 1.124 yamt LIST_INSERT_HEAD(&nfs_iodlist_all, myiod, nid_all);
1030 1.123 yamt mutex_exit(&nfs_iodlist_lock);
1031 1.118 yamt
1032 1.1 cgd for (;;) {
1033 1.124 yamt mutex_enter(&nfs_iodlist_lock);
1034 1.124 yamt LIST_INSERT_HEAD(&nfs_iodlist_idle, myiod, nid_idle);
1035 1.124 yamt mutex_exit(&nfs_iodlist_lock);
1036 1.124 yamt
1037 1.109 yamt mutex_enter(&myiod->nid_lock);
1038 1.106 thorpej while (/*CONSTCOND*/ true) {
1039 1.60 yamt nmp = myiod->nid_mount;
1040 1.60 yamt if (nmp) {
1041 1.124 yamt myiod->nid_mount = NULL;
1042 1.124 yamt break;
1043 1.124 yamt }
1044 1.124 yamt if (__predict_false(myiod->nid_exiting)) {
1045 1.124 yamt /*
1046 1.124 yamt * drop nid_lock to preserve locking order.
1047 1.124 yamt */
1048 1.124 yamt mutex_exit(&myiod->nid_lock);
1049 1.124 yamt mutex_enter(&nfs_iodlist_lock);
1050 1.124 yamt mutex_enter(&myiod->nid_lock);
1051 1.124 yamt /*
1052 1.124 yamt * recheck nid_mount because nfs_asyncio can
1053 1.124 yamt * pick us in the meantime as we are still on
1054 1.124 yamt * nfs_iodlist_lock.
1055 1.124 yamt */
1056 1.124 yamt if (myiod->nid_mount != NULL) {
1057 1.124 yamt mutex_exit(&nfs_iodlist_lock);
1058 1.124 yamt continue;
1059 1.60 yamt }
1060 1.124 yamt LIST_REMOVE(myiod, nid_idle);
1061 1.124 yamt mutex_exit(&nfs_iodlist_lock);
1062 1.60 yamt goto quit;
1063 1.110 yamt }
1064 1.118 yamt cv_wait(&myiod->nid_cv, &myiod->nid_lock);
1065 1.59 yamt }
1066 1.124 yamt mutex_exit(&myiod->nid_lock);
1067 1.60 yamt
1068 1.124 yamt mutex_enter(&nmp->nm_lock);
1069 1.60 yamt while ((bp = TAILQ_FIRST(&nmp->nm_bufq)) != NULL) {
1070 1.59 yamt /* Take one off the front of the list */
1071 1.59 yamt TAILQ_REMOVE(&nmp->nm_bufq, bp, b_freelist);
1072 1.59 yamt nmp->nm_bufqlen--;
1073 1.123 yamt if (nmp->nm_bufqlen < 2 * nmp->nm_bufqiods) {
1074 1.109 yamt cv_broadcast(&nmp->nm_aiocv);
1075 1.59 yamt }
1076 1.109 yamt mutex_exit(&nmp->nm_lock);
1077 1.124 yamt KERNEL_LOCK(1, curlwp);
1078 1.79 christos (void)nfs_doio(bp);
1079 1.124 yamt KERNEL_UNLOCK_LAST(curlwp);
1080 1.109 yamt mutex_enter(&nmp->nm_lock);
1081 1.59 yamt /*
1082 1.81 rpaulo * If there are more than one iod on this mount,
1083 1.81 rpaulo * then defect so that the iods can be shared out
1084 1.81 rpaulo * fairly between the mounts
1085 1.59 yamt */
1086 1.59 yamt if (nfs_defect && nmp->nm_bufqiods > 1) {
1087 1.59 yamt break;
1088 1.59 yamt }
1089 1.59 yamt }
1090 1.124 yamt KASSERT(nmp->nm_bufqiods > 0);
1091 1.124 yamt nmp->nm_bufqiods--;
1092 1.109 yamt mutex_exit(&nmp->nm_lock);
1093 1.1 cgd }
1094 1.60 yamt quit:
1095 1.124 yamt KASSERT(myiod->nid_mount == NULL);
1096 1.124 yamt mutex_exit(&myiod->nid_lock);
1097 1.124 yamt
1098 1.124 yamt cv_destroy(&myiod->nid_cv);
1099 1.124 yamt KERNEL_LOCK(1, curlwp);
1100 1.124 yamt mutex_destroy(&myiod->nid_lock);
1101 1.124 yamt kmem_free(myiod, sizeof(*myiod));
1102 1.124 yamt KERNEL_UNLOCK_LAST(curlwp);
1103 1.39 tsarna
1104 1.118 yamt kthread_exit(0);
1105 1.60 yamt }
1106 1.60 yamt
1107 1.60 yamt void
1108 1.60 yamt nfs_iodinit()
1109 1.60 yamt {
1110 1.60 yamt
1111 1.123 yamt mutex_init(&nfs_iodlist_lock, MUTEX_DEFAULT, IPL_NONE);
1112 1.124 yamt LIST_INIT(&nfs_iodlist_all);
1113 1.124 yamt LIST_INIT(&nfs_iodlist_idle);
1114 1.1 cgd }
1115 1.3 glass
1116 1.124 yamt int
1117 1.124 yamt nfs_set_niothreads(int newval)
1118 1.39 tsarna {
1119 1.124 yamt struct nfs_iod *nid;
1120 1.124 yamt int error = 0;
1121 1.124 yamt
1122 1.124 yamt #if defined(MULTIPROCESSOR)
1123 1.124 yamt int hold_count;
1124 1.124 yamt #endif /* defined(MULTIPROCESSOR) */
1125 1.124 yamt
1126 1.124 yamt KERNEL_UNLOCK_ALL(curlwp, &hold_count);
1127 1.78 perry
1128 1.123 yamt mutex_enter(&nfs_iodlist_lock);
1129 1.124 yamt /* clamp to sane range */
1130 1.124 yamt nfs_niothreads = max(0, min(newval, NFS_MAXASYNCDAEMON));
1131 1.39 tsarna
1132 1.124 yamt while (nfs_numasync != nfs_niothreads && error == 0) {
1133 1.124 yamt while (nfs_numasync < nfs_niothreads) {
1134 1.39 tsarna
1135 1.124 yamt /*
1136 1.124 yamt * kthread_create can wait for pagedaemon and
1137 1.124 yamt * pagedaemon can wait for nfsiod which needs to acquire
1138 1.124 yamt * nfs_iodlist_lock.
1139 1.124 yamt */
1140 1.124 yamt
1141 1.124 yamt mutex_exit(&nfs_iodlist_lock);
1142 1.124 yamt KERNEL_LOCK(1, curlwp);
1143 1.124 yamt error = kthread_create(PRI_NONE, KTHREAD_MPSAFE, NULL,
1144 1.123 yamt nfssvc_iod, NULL, NULL, "nfsio");
1145 1.124 yamt KERNEL_UNLOCK_LAST(curlwp);
1146 1.124 yamt mutex_enter(&nfs_iodlist_lock);
1147 1.124 yamt if (error) {
1148 1.124 yamt /* give up */
1149 1.124 yamt nfs_niothreads = nfs_numasync;
1150 1.124 yamt break;
1151 1.124 yamt }
1152 1.124 yamt nfs_numasync++;
1153 1.39 tsarna }
1154 1.124 yamt while (nfs_numasync > nfs_niothreads) {
1155 1.124 yamt nid = LIST_FIRST(&nfs_iodlist_all);
1156 1.124 yamt if (nid == NULL) {
1157 1.124 yamt /* iod has not started yet. */
1158 1.124 yamt kpause("nfsiorm", false, hz, &nfs_iodlist_lock);
1159 1.124 yamt continue;
1160 1.39 tsarna }
1161 1.124 yamt LIST_REMOVE(nid, nid_all);
1162 1.124 yamt mutex_enter(&nid->nid_lock);
1163 1.124 yamt KASSERT(!nid->nid_exiting);
1164 1.124 yamt nid->nid_exiting = true;
1165 1.124 yamt cv_signal(&nid->nid_cv);
1166 1.124 yamt mutex_exit(&nid->nid_lock);
1167 1.124 yamt nfs_numasync--;
1168 1.118 yamt }
1169 1.39 tsarna }
1170 1.123 yamt mutex_exit(&nfs_iodlist_lock);
1171 1.124 yamt
1172 1.124 yamt KERNEL_LOCK(hold_count, curlwp);
1173 1.124 yamt return error;
1174 1.39 tsarna }
1175 1.19 fvdl
1176 1.10 mycroft /*
1177 1.10 mycroft * Get an authorization string for the uid by having the mount_nfs sitting
1178 1.10 mycroft * on this mount point porpous out of the kernel and do it.
1179 1.10 mycroft */
1180 1.18 christos int
1181 1.19 fvdl nfs_getauth(nmp, rep, cred, auth_str, auth_len, verf_str, verf_len, key)
1182 1.38 augustss struct nfsmount *nmp;
1183 1.10 mycroft struct nfsreq *rep;
1184 1.92 elad kauth_cred_t cred;
1185 1.10 mycroft char **auth_str;
1186 1.10 mycroft int *auth_len;
1187 1.19 fvdl char *verf_str;
1188 1.19 fvdl int *verf_len;
1189 1.19 fvdl NFSKERBKEY_T key; /* return session key */
1190 1.10 mycroft {
1191 1.10 mycroft int error = 0;
1192 1.10 mycroft
1193 1.27 fvdl while ((nmp->nm_iflag & NFSMNT_WAITAUTH) == 0) {
1194 1.27 fvdl nmp->nm_iflag |= NFSMNT_WANTAUTH;
1195 1.107 christos (void) tsleep((void *)&nmp->nm_authtype, PSOCK,
1196 1.10 mycroft "nfsauth1", 2 * hz);
1197 1.84 christos error = nfs_sigintr(nmp, rep, rep->r_lwp);
1198 1.18 christos if (error) {
1199 1.27 fvdl nmp->nm_iflag &= ~NFSMNT_WANTAUTH;
1200 1.10 mycroft return (error);
1201 1.10 mycroft }
1202 1.10 mycroft }
1203 1.27 fvdl nmp->nm_iflag &= ~(NFSMNT_WAITAUTH | NFSMNT_WANTAUTH);
1204 1.10 mycroft nmp->nm_authstr = *auth_str = (char *)malloc(RPCAUTH_MAXSIZ, M_TEMP, M_WAITOK);
1205 1.19 fvdl nmp->nm_authlen = RPCAUTH_MAXSIZ;
1206 1.19 fvdl nmp->nm_verfstr = verf_str;
1207 1.19 fvdl nmp->nm_verflen = *verf_len;
1208 1.92 elad nmp->nm_authuid = kauth_cred_geteuid(cred);
1209 1.107 christos wakeup((void *)&nmp->nm_authstr);
1210 1.3 glass
1211 1.10 mycroft /*
1212 1.10 mycroft * And wait for mount_nfs to do its stuff.
1213 1.10 mycroft */
1214 1.27 fvdl while ((nmp->nm_iflag & NFSMNT_HASAUTH) == 0 && error == 0) {
1215 1.107 christos (void) tsleep((void *)&nmp->nm_authlen, PSOCK,
1216 1.10 mycroft "nfsauth2", 2 * hz);
1217 1.84 christos error = nfs_sigintr(nmp, rep, rep->r_lwp);
1218 1.10 mycroft }
1219 1.27 fvdl if (nmp->nm_iflag & NFSMNT_AUTHERR) {
1220 1.27 fvdl nmp->nm_iflag &= ~NFSMNT_AUTHERR;
1221 1.10 mycroft error = EAUTH;
1222 1.10 mycroft }
1223 1.10 mycroft if (error)
1224 1.107 christos free((void *)*auth_str, M_TEMP);
1225 1.10 mycroft else {
1226 1.10 mycroft *auth_len = nmp->nm_authlen;
1227 1.19 fvdl *verf_len = nmp->nm_verflen;
1228 1.52 chs memcpy(key, nmp->nm_key, sizeof (NFSKERBKEY_T));
1229 1.10 mycroft }
1230 1.27 fvdl nmp->nm_iflag &= ~NFSMNT_HASAUTH;
1231 1.27 fvdl nmp->nm_iflag |= NFSMNT_WAITAUTH;
1232 1.27 fvdl if (nmp->nm_iflag & NFSMNT_WANTAUTH) {
1233 1.27 fvdl nmp->nm_iflag &= ~NFSMNT_WANTAUTH;
1234 1.107 christos wakeup((void *)&nmp->nm_authtype);
1235 1.10 mycroft }
1236 1.19 fvdl return (error);
1237 1.19 fvdl }
1238 1.19 fvdl
1239 1.19 fvdl /*
1240 1.19 fvdl * Get a nickname authenticator and verifier.
1241 1.19 fvdl */
1242 1.19 fvdl int
1243 1.99 yamt nfs_getnickauth(struct nfsmount *nmp, kauth_cred_t cred, char **auth_str,
1244 1.99 yamt int *auth_len, char *verf_str, int verf_len)
1245 1.19 fvdl {
1246 1.95 kardel struct timeval ktvin, ktvout, tv;
1247 1.38 augustss struct nfsuid *nuidp;
1248 1.38 augustss u_int32_t *nickp, *verfp;
1249 1.19 fvdl
1250 1.91 mrg memset(&ktvout, 0, sizeof ktvout); /* XXX gcc */
1251 1.91 mrg
1252 1.19 fvdl #ifdef DIAGNOSTIC
1253 1.19 fvdl if (verf_len < (4 * NFSX_UNSIGNED))
1254 1.19 fvdl panic("nfs_getnickauth verf too small");
1255 1.19 fvdl #endif
1256 1.92 elad LIST_FOREACH(nuidp, NMUIDHASH(nmp, kauth_cred_geteuid(cred)), nu_hash) {
1257 1.92 elad if (kauth_cred_geteuid(nuidp->nu_cr) == kauth_cred_geteuid(cred))
1258 1.19 fvdl break;
1259 1.19 fvdl }
1260 1.95 kardel if (!nuidp || nuidp->nu_expire < time_second)
1261 1.19 fvdl return (EACCES);
1262 1.19 fvdl
1263 1.19 fvdl /*
1264 1.19 fvdl * Move to the end of the lru list (end of lru == most recently used).
1265 1.19 fvdl */
1266 1.19 fvdl TAILQ_REMOVE(&nmp->nm_uidlruhead, nuidp, nu_lru);
1267 1.19 fvdl TAILQ_INSERT_TAIL(&nmp->nm_uidlruhead, nuidp, nu_lru);
1268 1.19 fvdl
1269 1.19 fvdl nickp = (u_int32_t *)malloc(2 * NFSX_UNSIGNED, M_TEMP, M_WAITOK);
1270 1.19 fvdl *nickp++ = txdr_unsigned(RPCAKN_NICKNAME);
1271 1.19 fvdl *nickp = txdr_unsigned(nuidp->nu_nickname);
1272 1.19 fvdl *auth_str = (char *)nickp;
1273 1.19 fvdl *auth_len = 2 * NFSX_UNSIGNED;
1274 1.19 fvdl
1275 1.19 fvdl /*
1276 1.19 fvdl * Now we must encrypt the verifier and package it up.
1277 1.19 fvdl */
1278 1.19 fvdl verfp = (u_int32_t *)verf_str;
1279 1.19 fvdl *verfp++ = txdr_unsigned(RPCAKN_NICKNAME);
1280 1.95 kardel getmicrotime(&tv);
1281 1.95 kardel if (tv.tv_sec > nuidp->nu_timestamp.tv_sec ||
1282 1.95 kardel (tv.tv_sec == nuidp->nu_timestamp.tv_sec &&
1283 1.95 kardel tv.tv_usec > nuidp->nu_timestamp.tv_usec))
1284 1.95 kardel nuidp->nu_timestamp = tv;
1285 1.19 fvdl else
1286 1.19 fvdl nuidp->nu_timestamp.tv_usec++;
1287 1.19 fvdl ktvin.tv_sec = txdr_unsigned(nuidp->nu_timestamp.tv_sec);
1288 1.19 fvdl ktvin.tv_usec = txdr_unsigned(nuidp->nu_timestamp.tv_usec);
1289 1.19 fvdl
1290 1.19 fvdl /*
1291 1.19 fvdl * Now encrypt the timestamp verifier in ecb mode using the session
1292 1.19 fvdl * key.
1293 1.19 fvdl */
1294 1.19 fvdl #ifdef NFSKERB
1295 1.19 fvdl XXX
1296 1.19 fvdl #endif
1297 1.19 fvdl
1298 1.19 fvdl *verfp++ = ktvout.tv_sec;
1299 1.19 fvdl *verfp++ = ktvout.tv_usec;
1300 1.19 fvdl *verfp = 0;
1301 1.19 fvdl return (0);
1302 1.19 fvdl }
1303 1.19 fvdl
1304 1.19 fvdl /*
1305 1.19 fvdl * Save the current nickname in a hash list entry on the mount point.
1306 1.19 fvdl */
1307 1.19 fvdl int
1308 1.19 fvdl nfs_savenickauth(nmp, cred, len, key, mdp, dposp, mrep)
1309 1.38 augustss struct nfsmount *nmp;
1310 1.92 elad kauth_cred_t cred;
1311 1.19 fvdl int len;
1312 1.19 fvdl NFSKERBKEY_T key;
1313 1.19 fvdl struct mbuf **mdp;
1314 1.19 fvdl char **dposp;
1315 1.19 fvdl struct mbuf *mrep;
1316 1.19 fvdl {
1317 1.38 augustss struct nfsuid *nuidp;
1318 1.38 augustss u_int32_t *tl;
1319 1.38 augustss int32_t t1;
1320 1.19 fvdl struct mbuf *md = *mdp;
1321 1.19 fvdl struct timeval ktvin, ktvout;
1322 1.19 fvdl u_int32_t nick;
1323 1.19 fvdl char *dpos = *dposp, *cp2;
1324 1.19 fvdl int deltasec, error = 0;
1325 1.19 fvdl
1326 1.91 mrg memset(&ktvout, 0, sizeof ktvout); /* XXX gcc */
1327 1.91 mrg
1328 1.19 fvdl if (len == (3 * NFSX_UNSIGNED)) {
1329 1.19 fvdl nfsm_dissect(tl, u_int32_t *, 3 * NFSX_UNSIGNED);
1330 1.19 fvdl ktvin.tv_sec = *tl++;
1331 1.19 fvdl ktvin.tv_usec = *tl++;
1332 1.19 fvdl nick = fxdr_unsigned(u_int32_t, *tl);
1333 1.19 fvdl
1334 1.19 fvdl /*
1335 1.19 fvdl * Decrypt the timestamp in ecb mode.
1336 1.19 fvdl */
1337 1.19 fvdl #ifdef NFSKERB
1338 1.19 fvdl XXX
1339 1.19 fvdl #endif
1340 1.19 fvdl ktvout.tv_sec = fxdr_unsigned(long, ktvout.tv_sec);
1341 1.19 fvdl ktvout.tv_usec = fxdr_unsigned(long, ktvout.tv_usec);
1342 1.95 kardel deltasec = time_second - ktvout.tv_sec;
1343 1.19 fvdl if (deltasec < 0)
1344 1.19 fvdl deltasec = -deltasec;
1345 1.19 fvdl /*
1346 1.19 fvdl * If ok, add it to the hash list for the mount point.
1347 1.19 fvdl */
1348 1.19 fvdl if (deltasec <= NFS_KERBCLOCKSKEW) {
1349 1.19 fvdl if (nmp->nm_numuids < nuidhash_max) {
1350 1.19 fvdl nmp->nm_numuids++;
1351 1.19 fvdl nuidp = (struct nfsuid *)
1352 1.19 fvdl malloc(sizeof (struct nfsuid), M_NFSUID,
1353 1.19 fvdl M_WAITOK);
1354 1.19 fvdl } else {
1355 1.57 yamt nuidp = TAILQ_FIRST(&nmp->nm_uidlruhead);
1356 1.19 fvdl LIST_REMOVE(nuidp, nu_hash);
1357 1.19 fvdl TAILQ_REMOVE(&nmp->nm_uidlruhead, nuidp,
1358 1.19 fvdl nu_lru);
1359 1.19 fvdl }
1360 1.19 fvdl nuidp->nu_flag = 0;
1361 1.92 elad kauth_cred_seteuid(nuidp->nu_cr, kauth_cred_geteuid(cred));
1362 1.95 kardel nuidp->nu_expire = time_second + NFS_KERBTTL;
1363 1.19 fvdl nuidp->nu_timestamp = ktvout;
1364 1.19 fvdl nuidp->nu_nickname = nick;
1365 1.52 chs memcpy(nuidp->nu_key, key, sizeof (NFSKERBKEY_T));
1366 1.19 fvdl TAILQ_INSERT_TAIL(&nmp->nm_uidlruhead, nuidp,
1367 1.19 fvdl nu_lru);
1368 1.92 elad LIST_INSERT_HEAD(NMUIDHASH(nmp, kauth_cred_geteuid(cred)),
1369 1.19 fvdl nuidp, nu_hash);
1370 1.19 fvdl }
1371 1.19 fvdl } else
1372 1.19 fvdl nfsm_adv(nfsm_rndup(len));
1373 1.19 fvdl nfsmout:
1374 1.19 fvdl *mdp = md;
1375 1.19 fvdl *dposp = dpos;
1376 1.10 mycroft return (error);
1377 1.10 mycroft }
1378 1.24 thorpej #endif /* NFS */
1379