nfs_srvsocket.c revision 1.3.2.2
1 1.3.2.2 yamt /* $NetBSD: nfs_srvsocket.c,v 1.3.2.2 2009/05/04 08:14:22 yamt Exp $ */ 2 1.3.2.2 yamt 3 1.3.2.2 yamt /* 4 1.3.2.2 yamt * Copyright (c) 1989, 1991, 1993, 1995 5 1.3.2.2 yamt * The Regents of the University of California. All rights reserved. 6 1.3.2.2 yamt * 7 1.3.2.2 yamt * This code is derived from software contributed to Berkeley by 8 1.3.2.2 yamt * Rick Macklem at The University of Guelph. 9 1.3.2.2 yamt * 10 1.3.2.2 yamt * Redistribution and use in source and binary forms, with or without 11 1.3.2.2 yamt * modification, are permitted provided that the following conditions 12 1.3.2.2 yamt * are met: 13 1.3.2.2 yamt * 1. Redistributions of source code must retain the above copyright 14 1.3.2.2 yamt * notice, this list of conditions and the following disclaimer. 15 1.3.2.2 yamt * 2. Redistributions in binary form must reproduce the above copyright 16 1.3.2.2 yamt * notice, this list of conditions and the following disclaimer in the 17 1.3.2.2 yamt * documentation and/or other materials provided with the distribution. 18 1.3.2.2 yamt * 3. Neither the name of the University nor the names of its contributors 19 1.3.2.2 yamt * may be used to endorse or promote products derived from this software 20 1.3.2.2 yamt * without specific prior written permission. 21 1.3.2.2 yamt * 22 1.3.2.2 yamt * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 23 1.3.2.2 yamt * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 24 1.3.2.2 yamt * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 25 1.3.2.2 yamt * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 26 1.3.2.2 yamt * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 27 1.3.2.2 yamt * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 28 1.3.2.2 yamt * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 29 1.3.2.2 yamt * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 30 1.3.2.2 yamt * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 31 1.3.2.2 yamt * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 32 1.3.2.2 yamt * SUCH DAMAGE. 33 1.3.2.2 yamt * 34 1.3.2.2 yamt * @(#)nfs_socket.c 8.5 (Berkeley) 3/30/95 35 1.3.2.2 yamt */ 36 1.3.2.2 yamt 37 1.3.2.2 yamt /* 38 1.3.2.2 yamt * Socket operations for use by nfs 39 1.3.2.2 yamt */ 40 1.3.2.2 yamt 41 1.3.2.2 yamt #include <sys/cdefs.h> 42 1.3.2.2 yamt __KERNEL_RCSID(0, "$NetBSD: nfs_srvsocket.c,v 1.3.2.2 2009/05/04 08:14:22 yamt Exp $"); 43 1.3.2.2 yamt 44 1.3.2.2 yamt #include <sys/param.h> 45 1.3.2.2 yamt #include <sys/systm.h> 46 1.3.2.2 yamt #include <sys/evcnt.h> 47 1.3.2.2 yamt #include <sys/callout.h> 48 1.3.2.2 yamt #include <sys/proc.h> 49 1.3.2.2 yamt #include <sys/mount.h> 50 1.3.2.2 yamt #include <sys/kernel.h> 51 1.3.2.2 yamt #include <sys/kmem.h> 52 1.3.2.2 yamt #include <sys/mbuf.h> 53 1.3.2.2 yamt #include <sys/vnode.h> 54 1.3.2.2 yamt #include <sys/domain.h> 55 1.3.2.2 yamt #include <sys/protosw.h> 56 1.3.2.2 yamt #include <sys/socket.h> 57 1.3.2.2 yamt #include <sys/socketvar.h> 58 1.3.2.2 yamt #include <sys/syslog.h> 59 1.3.2.2 yamt #include <sys/tprintf.h> 60 1.3.2.2 yamt #include <sys/namei.h> 61 1.3.2.2 yamt #include <sys/signal.h> 62 1.3.2.2 yamt #include <sys/signalvar.h> 63 1.3.2.2 yamt #include <sys/kauth.h> 64 1.3.2.2 yamt 65 1.3.2.2 yamt #include <netinet/in.h> 66 1.3.2.2 yamt #include <netinet/tcp.h> 67 1.3.2.2 yamt 68 1.3.2.2 yamt #include <nfs/rpcv2.h> 69 1.3.2.2 yamt #include <nfs/nfsproto.h> 70 1.3.2.2 yamt #include <nfs/nfs.h> 71 1.3.2.2 yamt #include <nfs/xdr_subs.h> 72 1.3.2.2 yamt #include <nfs/nfsm_subs.h> 73 1.3.2.2 yamt #include <nfs/nfsmount.h> 74 1.3.2.2 yamt #include <nfs/nfsnode.h> 75 1.3.2.2 yamt #include <nfs/nfsrtt.h> 76 1.3.2.2 yamt #include <nfs/nfs_var.h> 77 1.3.2.2 yamt 78 1.3.2.2 yamt static void nfsrv_wakenfsd_locked(struct nfssvc_sock *); 79 1.3.2.2 yamt 80 1.3.2.2 yamt int (*nfsrv3_procs[NFS_NPROCS])(struct nfsrv_descript *, 81 1.3.2.2 yamt struct nfssvc_sock *, struct lwp *, 82 1.3.2.2 yamt struct mbuf **) = { 83 1.3.2.2 yamt nfsrv_null, 84 1.3.2.2 yamt nfsrv_getattr, 85 1.3.2.2 yamt nfsrv_setattr, 86 1.3.2.2 yamt nfsrv_lookup, 87 1.3.2.2 yamt nfsrv3_access, 88 1.3.2.2 yamt nfsrv_readlink, 89 1.3.2.2 yamt nfsrv_read, 90 1.3.2.2 yamt nfsrv_write, 91 1.3.2.2 yamt nfsrv_create, 92 1.3.2.2 yamt nfsrv_mkdir, 93 1.3.2.2 yamt nfsrv_symlink, 94 1.3.2.2 yamt nfsrv_mknod, 95 1.3.2.2 yamt nfsrv_remove, 96 1.3.2.2 yamt nfsrv_rmdir, 97 1.3.2.2 yamt nfsrv_rename, 98 1.3.2.2 yamt nfsrv_link, 99 1.3.2.2 yamt nfsrv_readdir, 100 1.3.2.2 yamt nfsrv_readdirplus, 101 1.3.2.2 yamt nfsrv_statfs, 102 1.3.2.2 yamt nfsrv_fsinfo, 103 1.3.2.2 yamt nfsrv_pathconf, 104 1.3.2.2 yamt nfsrv_commit, 105 1.3.2.2 yamt nfsrv_noop 106 1.3.2.2 yamt }; 107 1.3.2.2 yamt 108 1.3.2.2 yamt /* 109 1.3.2.2 yamt * Socket upcall routine for the nfsd sockets. 110 1.3.2.2 yamt * The void *arg is a pointer to the "struct nfssvc_sock". 111 1.3.2.2 yamt */ 112 1.3.2.2 yamt void 113 1.3.2.2 yamt nfsrv_soupcall(struct socket *so, void *arg, int waitflag) 114 1.3.2.2 yamt { 115 1.3.2.2 yamt struct nfssvc_sock *slp = (struct nfssvc_sock *)arg; 116 1.3.2.2 yamt 117 1.3.2.2 yamt nfsdsock_setbits(slp, SLP_A_NEEDQ); 118 1.3.2.2 yamt nfsrv_wakenfsd(slp); 119 1.3.2.2 yamt } 120 1.3.2.2 yamt 121 1.3.2.2 yamt void 122 1.3.2.2 yamt nfsrv_rcv(struct nfssvc_sock *slp) 123 1.3.2.2 yamt { 124 1.3.2.2 yamt struct socket *so; 125 1.3.2.2 yamt struct mbuf *m; 126 1.3.2.2 yamt struct mbuf *mp, *nam; 127 1.3.2.2 yamt struct uio auio; 128 1.3.2.2 yamt int flags; 129 1.3.2.2 yamt int error; 130 1.3.2.2 yamt int setflags = 0; 131 1.3.2.2 yamt 132 1.3.2.2 yamt error = nfsdsock_lock(slp, true); 133 1.3.2.2 yamt if (error) { 134 1.3.2.2 yamt setflags |= SLP_A_NEEDQ; 135 1.3.2.2 yamt goto dorecs_unlocked; 136 1.3.2.2 yamt } 137 1.3.2.2 yamt 138 1.3.2.2 yamt nfsdsock_clearbits(slp, SLP_A_NEEDQ); 139 1.3.2.2 yamt 140 1.3.2.2 yamt so = slp->ns_so; 141 1.3.2.2 yamt if (so->so_type == SOCK_STREAM) { 142 1.3.2.2 yamt /* 143 1.3.2.2 yamt * Do soreceive(). 144 1.3.2.2 yamt */ 145 1.3.2.2 yamt auio.uio_resid = 1000000000; 146 1.3.2.2 yamt /* not need to setup uio_vmspace */ 147 1.3.2.2 yamt flags = MSG_DONTWAIT; 148 1.3.2.2 yamt error = (*so->so_receive)(so, &nam, &auio, &mp, NULL, &flags); 149 1.3.2.2 yamt if (error || mp == NULL) { 150 1.3.2.2 yamt if (error == EWOULDBLOCK) 151 1.3.2.2 yamt setflags |= SLP_A_NEEDQ; 152 1.3.2.2 yamt else 153 1.3.2.2 yamt setflags |= SLP_A_DISCONN; 154 1.3.2.2 yamt goto dorecs; 155 1.3.2.2 yamt } 156 1.3.2.2 yamt m = mp; 157 1.3.2.2 yamt m_claimm(m, &nfs_mowner); 158 1.3.2.2 yamt if (slp->ns_rawend) { 159 1.3.2.2 yamt slp->ns_rawend->m_next = m; 160 1.3.2.2 yamt slp->ns_cc += 1000000000 - auio.uio_resid; 161 1.3.2.2 yamt } else { 162 1.3.2.2 yamt slp->ns_raw = m; 163 1.3.2.2 yamt slp->ns_cc = 1000000000 - auio.uio_resid; 164 1.3.2.2 yamt } 165 1.3.2.2 yamt while (m->m_next) 166 1.3.2.2 yamt m = m->m_next; 167 1.3.2.2 yamt slp->ns_rawend = m; 168 1.3.2.2 yamt 169 1.3.2.2 yamt /* 170 1.3.2.2 yamt * Now try and parse record(s) out of the raw stream data. 171 1.3.2.2 yamt */ 172 1.3.2.2 yamt error = nfsrv_getstream(slp, M_WAIT); 173 1.3.2.2 yamt if (error) { 174 1.3.2.2 yamt if (error == EPERM) 175 1.3.2.2 yamt setflags |= SLP_A_DISCONN; 176 1.3.2.2 yamt else 177 1.3.2.2 yamt setflags |= SLP_A_NEEDQ; 178 1.3.2.2 yamt } 179 1.3.2.2 yamt } else { 180 1.3.2.2 yamt do { 181 1.3.2.2 yamt auio.uio_resid = 1000000000; 182 1.3.2.2 yamt /* not need to setup uio_vmspace */ 183 1.3.2.2 yamt flags = MSG_DONTWAIT; 184 1.3.2.2 yamt error = (*so->so_receive)(so, &nam, &auio, &mp, NULL, 185 1.3.2.2 yamt &flags); 186 1.3.2.2 yamt if (mp) { 187 1.3.2.2 yamt if (nam) { 188 1.3.2.2 yamt m = nam; 189 1.3.2.2 yamt m->m_next = mp; 190 1.3.2.2 yamt } else 191 1.3.2.2 yamt m = mp; 192 1.3.2.2 yamt m_claimm(m, &nfs_mowner); 193 1.3.2.2 yamt if (slp->ns_recend) 194 1.3.2.2 yamt slp->ns_recend->m_nextpkt = m; 195 1.3.2.2 yamt else 196 1.3.2.2 yamt slp->ns_rec = m; 197 1.3.2.2 yamt slp->ns_recend = m; 198 1.3.2.2 yamt m->m_nextpkt = (struct mbuf *)0; 199 1.3.2.2 yamt } 200 1.3.2.2 yamt if (error) { 201 1.3.2.2 yamt if ((so->so_proto->pr_flags & PR_CONNREQUIRED) 202 1.3.2.2 yamt && error != EWOULDBLOCK) { 203 1.3.2.2 yamt setflags |= SLP_A_DISCONN; 204 1.3.2.2 yamt goto dorecs; 205 1.3.2.2 yamt } 206 1.3.2.2 yamt } 207 1.3.2.2 yamt } while (mp); 208 1.3.2.2 yamt } 209 1.3.2.2 yamt dorecs: 210 1.3.2.2 yamt nfsdsock_unlock(slp); 211 1.3.2.2 yamt 212 1.3.2.2 yamt dorecs_unlocked: 213 1.3.2.2 yamt if (setflags) { 214 1.3.2.2 yamt nfsdsock_setbits(slp, setflags); 215 1.3.2.2 yamt } 216 1.3.2.2 yamt } 217 1.3.2.2 yamt 218 1.3.2.2 yamt int 219 1.3.2.2 yamt nfsdsock_lock(struct nfssvc_sock *slp, bool waitok) 220 1.3.2.2 yamt { 221 1.3.2.2 yamt 222 1.3.2.2 yamt mutex_enter(&slp->ns_lock); 223 1.3.2.2 yamt while ((~slp->ns_flags & (SLP_BUSY|SLP_VALID)) == 0) { 224 1.3.2.2 yamt if (!waitok) { 225 1.3.2.2 yamt mutex_exit(&slp->ns_lock); 226 1.3.2.2 yamt return EWOULDBLOCK; 227 1.3.2.2 yamt } 228 1.3.2.2 yamt cv_wait(&slp->ns_cv, &slp->ns_lock); 229 1.3.2.2 yamt } 230 1.3.2.2 yamt if ((slp->ns_flags & SLP_VALID) == 0) { 231 1.3.2.2 yamt mutex_exit(&slp->ns_lock); 232 1.3.2.2 yamt return EINVAL; 233 1.3.2.2 yamt } 234 1.3.2.2 yamt KASSERT((slp->ns_flags & SLP_BUSY) == 0); 235 1.3.2.2 yamt slp->ns_flags |= SLP_BUSY; 236 1.3.2.2 yamt mutex_exit(&slp->ns_lock); 237 1.3.2.2 yamt 238 1.3.2.2 yamt return 0; 239 1.3.2.2 yamt } 240 1.3.2.2 yamt 241 1.3.2.2 yamt void 242 1.3.2.2 yamt nfsdsock_unlock(struct nfssvc_sock *slp) 243 1.3.2.2 yamt { 244 1.3.2.2 yamt 245 1.3.2.2 yamt mutex_enter(&slp->ns_lock); 246 1.3.2.2 yamt KASSERT((slp->ns_flags & SLP_BUSY) != 0); 247 1.3.2.2 yamt cv_broadcast(&slp->ns_cv); 248 1.3.2.2 yamt slp->ns_flags &= ~SLP_BUSY; 249 1.3.2.2 yamt mutex_exit(&slp->ns_lock); 250 1.3.2.2 yamt } 251 1.3.2.2 yamt 252 1.3.2.2 yamt int 253 1.3.2.2 yamt nfsdsock_drain(struct nfssvc_sock *slp) 254 1.3.2.2 yamt { 255 1.3.2.2 yamt int error = 0; 256 1.3.2.2 yamt 257 1.3.2.2 yamt mutex_enter(&slp->ns_lock); 258 1.3.2.2 yamt if ((slp->ns_flags & SLP_VALID) == 0) { 259 1.3.2.2 yamt error = EINVAL; 260 1.3.2.2 yamt goto done; 261 1.3.2.2 yamt } 262 1.3.2.2 yamt slp->ns_flags &= ~SLP_VALID; 263 1.3.2.2 yamt while ((slp->ns_flags & SLP_BUSY) != 0) { 264 1.3.2.2 yamt cv_wait(&slp->ns_cv, &slp->ns_lock); 265 1.3.2.2 yamt } 266 1.3.2.2 yamt done: 267 1.3.2.2 yamt mutex_exit(&slp->ns_lock); 268 1.3.2.2 yamt 269 1.3.2.2 yamt return error; 270 1.3.2.2 yamt } 271 1.3.2.2 yamt 272 1.3.2.2 yamt /* 273 1.3.2.2 yamt * Try and extract an RPC request from the mbuf data list received on a 274 1.3.2.2 yamt * stream socket. The "waitflag" argument indicates whether or not it 275 1.3.2.2 yamt * can sleep. 276 1.3.2.2 yamt */ 277 1.3.2.2 yamt int 278 1.3.2.2 yamt nfsrv_getstream(struct nfssvc_sock *slp, int waitflag) 279 1.3.2.2 yamt { 280 1.3.2.2 yamt struct mbuf *m, **mpp; 281 1.3.2.2 yamt struct mbuf *recm; 282 1.3.2.2 yamt u_int32_t recmark; 283 1.3.2.2 yamt int error = 0; 284 1.3.2.2 yamt 285 1.3.2.2 yamt KASSERT((slp->ns_flags & SLP_BUSY) != 0); 286 1.3.2.2 yamt for (;;) { 287 1.3.2.2 yamt if (slp->ns_reclen == 0) { 288 1.3.2.2 yamt if (slp->ns_cc < NFSX_UNSIGNED) { 289 1.3.2.2 yamt break; 290 1.3.2.2 yamt } 291 1.3.2.2 yamt m = slp->ns_raw; 292 1.3.2.2 yamt m_copydata(m, 0, NFSX_UNSIGNED, (void *)&recmark); 293 1.3.2.2 yamt m_adj(m, NFSX_UNSIGNED); 294 1.3.2.2 yamt slp->ns_cc -= NFSX_UNSIGNED; 295 1.3.2.2 yamt recmark = ntohl(recmark); 296 1.3.2.2 yamt slp->ns_reclen = recmark & ~0x80000000; 297 1.3.2.2 yamt if (recmark & 0x80000000) 298 1.3.2.2 yamt slp->ns_sflags |= SLP_S_LASTFRAG; 299 1.3.2.2 yamt else 300 1.3.2.2 yamt slp->ns_sflags &= ~SLP_S_LASTFRAG; 301 1.3.2.2 yamt if (slp->ns_reclen > NFS_MAXPACKET) { 302 1.3.2.2 yamt error = EPERM; 303 1.3.2.2 yamt break; 304 1.3.2.2 yamt } 305 1.3.2.2 yamt } 306 1.3.2.2 yamt 307 1.3.2.2 yamt /* 308 1.3.2.2 yamt * Now get the record part. 309 1.3.2.2 yamt * 310 1.3.2.2 yamt * Note that slp->ns_reclen may be 0. Linux sometimes 311 1.3.2.2 yamt * generates 0-length records. 312 1.3.2.2 yamt */ 313 1.3.2.2 yamt if (slp->ns_cc == slp->ns_reclen) { 314 1.3.2.2 yamt recm = slp->ns_raw; 315 1.3.2.2 yamt slp->ns_raw = slp->ns_rawend = (struct mbuf *)0; 316 1.3.2.2 yamt slp->ns_cc = slp->ns_reclen = 0; 317 1.3.2.2 yamt } else if (slp->ns_cc > slp->ns_reclen) { 318 1.3.2.2 yamt recm = slp->ns_raw; 319 1.3.2.2 yamt m = m_split(recm, slp->ns_reclen, waitflag); 320 1.3.2.2 yamt if (m == NULL) { 321 1.3.2.2 yamt error = EWOULDBLOCK; 322 1.3.2.2 yamt break; 323 1.3.2.2 yamt } 324 1.3.2.2 yamt m_claimm(recm, &nfs_mowner); 325 1.3.2.2 yamt slp->ns_raw = m; 326 1.3.2.2 yamt if (m->m_next == NULL) 327 1.3.2.2 yamt slp->ns_rawend = m; 328 1.3.2.2 yamt slp->ns_cc -= slp->ns_reclen; 329 1.3.2.2 yamt slp->ns_reclen = 0; 330 1.3.2.2 yamt } else { 331 1.3.2.2 yamt break; 332 1.3.2.2 yamt } 333 1.3.2.2 yamt 334 1.3.2.2 yamt /* 335 1.3.2.2 yamt * Accumulate the fragments into a record. 336 1.3.2.2 yamt */ 337 1.3.2.2 yamt mpp = &slp->ns_frag; 338 1.3.2.2 yamt while (*mpp) 339 1.3.2.2 yamt mpp = &((*mpp)->m_next); 340 1.3.2.2 yamt *mpp = recm; 341 1.3.2.2 yamt if (slp->ns_sflags & SLP_S_LASTFRAG) { 342 1.3.2.2 yamt if (slp->ns_recend) 343 1.3.2.2 yamt slp->ns_recend->m_nextpkt = slp->ns_frag; 344 1.3.2.2 yamt else 345 1.3.2.2 yamt slp->ns_rec = slp->ns_frag; 346 1.3.2.2 yamt slp->ns_recend = slp->ns_frag; 347 1.3.2.2 yamt slp->ns_frag = NULL; 348 1.3.2.2 yamt } 349 1.3.2.2 yamt } 350 1.3.2.2 yamt 351 1.3.2.2 yamt return error; 352 1.3.2.2 yamt } 353 1.3.2.2 yamt 354 1.3.2.2 yamt /* 355 1.3.2.2 yamt * Parse an RPC header. 356 1.3.2.2 yamt */ 357 1.3.2.2 yamt int 358 1.3.2.2 yamt nfsrv_dorec(struct nfssvc_sock *slp, struct nfsd *nfsd, 359 1.3.2.2 yamt struct nfsrv_descript **ndp, bool *more) 360 1.3.2.2 yamt { 361 1.3.2.2 yamt struct mbuf *m, *nam; 362 1.3.2.2 yamt struct nfsrv_descript *nd; 363 1.3.2.2 yamt int error; 364 1.3.2.2 yamt 365 1.3.2.2 yamt *ndp = NULL; 366 1.3.2.2 yamt *more = false; 367 1.3.2.2 yamt 368 1.3.2.2 yamt if (nfsdsock_lock(slp, true)) { 369 1.3.2.2 yamt return ENOBUFS; 370 1.3.2.2 yamt } 371 1.3.2.2 yamt m = slp->ns_rec; 372 1.3.2.2 yamt if (m == NULL) { 373 1.3.2.2 yamt nfsdsock_unlock(slp); 374 1.3.2.2 yamt return ENOBUFS; 375 1.3.2.2 yamt } 376 1.3.2.2 yamt slp->ns_rec = m->m_nextpkt; 377 1.3.2.2 yamt if (slp->ns_rec) { 378 1.3.2.2 yamt m->m_nextpkt = NULL; 379 1.3.2.2 yamt *more = true; 380 1.3.2.2 yamt } else { 381 1.3.2.2 yamt slp->ns_recend = NULL; 382 1.3.2.2 yamt } 383 1.3.2.2 yamt nfsdsock_unlock(slp); 384 1.3.2.2 yamt 385 1.3.2.2 yamt if (m->m_type == MT_SONAME) { 386 1.3.2.2 yamt nam = m; 387 1.3.2.2 yamt m = m->m_next; 388 1.3.2.2 yamt nam->m_next = NULL; 389 1.3.2.2 yamt } else 390 1.3.2.2 yamt nam = NULL; 391 1.3.2.2 yamt nd = nfsdreq_alloc(); 392 1.3.2.2 yamt nd->nd_md = nd->nd_mrep = m; 393 1.3.2.2 yamt nd->nd_nam2 = nam; 394 1.3.2.2 yamt nd->nd_dpos = mtod(m, void *); 395 1.3.2.2 yamt error = nfs_getreq(nd, nfsd, true); 396 1.3.2.2 yamt if (error) { 397 1.3.2.2 yamt m_freem(nam); 398 1.3.2.2 yamt nfsdreq_free(nd); 399 1.3.2.2 yamt return (error); 400 1.3.2.2 yamt } 401 1.3.2.2 yamt *ndp = nd; 402 1.3.2.2 yamt nfsd->nfsd_nd = nd; 403 1.3.2.2 yamt return (0); 404 1.3.2.2 yamt } 405 1.3.2.2 yamt 406 1.3.2.2 yamt bool 407 1.3.2.2 yamt nfsrv_timer(void) 408 1.3.2.2 yamt { 409 1.3.2.2 yamt struct timeval tv; 410 1.3.2.2 yamt struct nfssvc_sock *slp; 411 1.3.2.2 yamt u_quad_t cur_usec; 412 1.3.2.2 yamt struct nfsrv_descript *nd; 413 1.3.2.2 yamt bool more; 414 1.3.2.2 yamt 415 1.3.2.2 yamt /* 416 1.3.2.2 yamt * Scan the write gathering queues for writes that need to be 417 1.3.2.2 yamt * completed now. 418 1.3.2.2 yamt */ 419 1.3.2.2 yamt getmicrotime(&tv); 420 1.3.2.2 yamt cur_usec = (u_quad_t)tv.tv_sec * 1000000 + (u_quad_t)tv.tv_usec; 421 1.3.2.2 yamt more = false; 422 1.3.2.2 yamt mutex_enter(&nfsd_lock); 423 1.3.2.2 yamt TAILQ_FOREACH(slp, &nfssvc_sockhead, ns_chain) { 424 1.3.2.2 yamt nd = LIST_FIRST(&slp->ns_tq); 425 1.3.2.2 yamt if (nd != NULL) { 426 1.3.2.2 yamt if (nd->nd_time <= cur_usec) { 427 1.3.2.2 yamt nfsrv_wakenfsd_locked(slp); 428 1.3.2.2 yamt } 429 1.3.2.2 yamt more = true; 430 1.3.2.2 yamt } 431 1.3.2.2 yamt } 432 1.3.2.2 yamt mutex_exit(&nfsd_lock); 433 1.3.2.2 yamt return more; 434 1.3.2.2 yamt } 435 1.3.2.2 yamt 436 1.3.2.2 yamt /* 437 1.3.2.2 yamt * Search for a sleeping nfsd and wake it up. 438 1.3.2.2 yamt * SIDE EFFECT: If none found, set NFSD_CHECKSLP flag, so that one of the 439 1.3.2.2 yamt * running nfsds will go look for the work in the nfssvc_sock list. 440 1.3.2.2 yamt */ 441 1.3.2.2 yamt static void 442 1.3.2.2 yamt nfsrv_wakenfsd_locked(struct nfssvc_sock *slp) 443 1.3.2.2 yamt { 444 1.3.2.2 yamt struct nfsd *nd; 445 1.3.2.2 yamt 446 1.3.2.2 yamt KASSERT(mutex_owned(&nfsd_lock)); 447 1.3.2.2 yamt 448 1.3.2.2 yamt if ((slp->ns_flags & SLP_VALID) == 0) 449 1.3.2.2 yamt return; 450 1.3.2.2 yamt if (slp->ns_gflags & SLP_G_DOREC) 451 1.3.2.2 yamt return; 452 1.3.2.2 yamt nd = SLIST_FIRST(&nfsd_idle_head); 453 1.3.2.2 yamt if (nd) { 454 1.3.2.2 yamt SLIST_REMOVE_HEAD(&nfsd_idle_head, nfsd_idle); 455 1.3.2.2 yamt if (nd->nfsd_slp) 456 1.3.2.2 yamt panic("nfsd wakeup"); 457 1.3.2.2 yamt slp->ns_sref++; 458 1.3.2.2 yamt KASSERT(slp->ns_sref > 0); 459 1.3.2.2 yamt nd->nfsd_slp = slp; 460 1.3.2.2 yamt cv_signal(&nd->nfsd_cv); 461 1.3.2.2 yamt } else { 462 1.3.2.2 yamt slp->ns_gflags |= SLP_G_DOREC; 463 1.3.2.2 yamt nfsd_head_flag |= NFSD_CHECKSLP; 464 1.3.2.2 yamt TAILQ_INSERT_TAIL(&nfssvc_sockpending, slp, ns_pending); 465 1.3.2.2 yamt } 466 1.3.2.2 yamt } 467 1.3.2.2 yamt 468 1.3.2.2 yamt void 469 1.3.2.2 yamt nfsrv_wakenfsd(struct nfssvc_sock *slp) 470 1.3.2.2 yamt { 471 1.3.2.2 yamt 472 1.3.2.2 yamt mutex_enter(&nfsd_lock); 473 1.3.2.2 yamt nfsrv_wakenfsd_locked(slp); 474 1.3.2.2 yamt mutex_exit(&nfsd_lock); 475 1.3.2.2 yamt } 476 1.3.2.2 yamt 477 1.3.2.2 yamt int 478 1.3.2.2 yamt nfsdsock_sendreply(struct nfssvc_sock *slp, struct nfsrv_descript *nd) 479 1.3.2.2 yamt { 480 1.3.2.2 yamt int error; 481 1.3.2.2 yamt 482 1.3.2.2 yamt if (nd->nd_mrep != NULL) { 483 1.3.2.2 yamt m_freem(nd->nd_mrep); 484 1.3.2.2 yamt nd->nd_mrep = NULL; 485 1.3.2.2 yamt } 486 1.3.2.2 yamt 487 1.3.2.2 yamt mutex_enter(&slp->ns_lock); 488 1.3.2.2 yamt if ((slp->ns_flags & SLP_SENDING) != 0) { 489 1.3.2.2 yamt SIMPLEQ_INSERT_TAIL(&slp->ns_sendq, nd, nd_sendq); 490 1.3.2.2 yamt mutex_exit(&slp->ns_lock); 491 1.3.2.2 yamt return 0; 492 1.3.2.2 yamt } 493 1.3.2.2 yamt KASSERT(SIMPLEQ_EMPTY(&slp->ns_sendq)); 494 1.3.2.2 yamt slp->ns_flags |= SLP_SENDING; 495 1.3.2.2 yamt mutex_exit(&slp->ns_lock); 496 1.3.2.2 yamt 497 1.3.2.2 yamt again: 498 1.3.2.2 yamt error = nfs_send(slp->ns_so, nd->nd_nam2, nd->nd_mreq, NULL, curlwp); 499 1.3.2.2 yamt if (nd->nd_nam2) { 500 1.3.2.2 yamt m_free(nd->nd_nam2); 501 1.3.2.2 yamt } 502 1.3.2.2 yamt nfsdreq_free(nd); 503 1.3.2.2 yamt 504 1.3.2.2 yamt mutex_enter(&slp->ns_lock); 505 1.3.2.2 yamt KASSERT((slp->ns_flags & SLP_SENDING) != 0); 506 1.3.2.2 yamt nd = SIMPLEQ_FIRST(&slp->ns_sendq); 507 1.3.2.2 yamt if (nd != NULL) { 508 1.3.2.2 yamt SIMPLEQ_REMOVE_HEAD(&slp->ns_sendq, nd_sendq); 509 1.3.2.2 yamt mutex_exit(&slp->ns_lock); 510 1.3.2.2 yamt goto again; 511 1.3.2.2 yamt } 512 1.3.2.2 yamt slp->ns_flags &= ~SLP_SENDING; 513 1.3.2.2 yamt mutex_exit(&slp->ns_lock); 514 1.3.2.2 yamt 515 1.3.2.2 yamt return error; 516 1.3.2.2 yamt } 517 1.3.2.2 yamt 518 1.3.2.2 yamt void 519 1.3.2.2 yamt nfsdsock_setbits(struct nfssvc_sock *slp, int bits) 520 1.3.2.2 yamt { 521 1.3.2.2 yamt 522 1.3.2.2 yamt mutex_enter(&slp->ns_alock); 523 1.3.2.2 yamt slp->ns_aflags |= bits; 524 1.3.2.2 yamt mutex_exit(&slp->ns_alock); 525 1.3.2.2 yamt } 526 1.3.2.2 yamt 527 1.3.2.2 yamt void 528 1.3.2.2 yamt nfsdsock_clearbits(struct nfssvc_sock *slp, int bits) 529 1.3.2.2 yamt { 530 1.3.2.2 yamt 531 1.3.2.2 yamt mutex_enter(&slp->ns_alock); 532 1.3.2.2 yamt slp->ns_aflags &= ~bits; 533 1.3.2.2 yamt mutex_exit(&slp->ns_alock); 534 1.3.2.2 yamt } 535 1.3.2.2 yamt 536 1.3.2.2 yamt bool 537 1.3.2.2 yamt nfsdsock_testbits(struct nfssvc_sock *slp, int bits) 538 1.3.2.2 yamt { 539 1.3.2.2 yamt 540 1.3.2.2 yamt return (slp->ns_aflags & bits); 541 1.3.2.2 yamt } 542
Indexes created Tue Sep 30 11:09:46 GMT 2025