fifo_vnops.c revision 1.49 1 1.49 jonathan /* $NetBSD: fifo_vnops.c,v 1.49 2004/05/22 22:52:14 jonathan Exp $ */
2 1.9 cgd
3 1.1 cgd /*
4 1.25 fvdl * Copyright (c) 1990, 1993, 1995
5 1.8 mycroft * The Regents of the University of California. All rights reserved.
6 1.1 cgd *
7 1.1 cgd * Redistribution and use in source and binary forms, with or without
8 1.1 cgd * modification, are permitted provided that the following conditions
9 1.1 cgd * are met:
10 1.1 cgd * 1. Redistributions of source code must retain the above copyright
11 1.1 cgd * notice, this list of conditions and the following disclaimer.
12 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 cgd * notice, this list of conditions and the following disclaimer in the
14 1.1 cgd * documentation and/or other materials provided with the distribution.
15 1.42 agc * 3. Neither the name of the University nor the names of its contributors
16 1.1 cgd * may be used to endorse or promote products derived from this software
17 1.1 cgd * without specific prior written permission.
18 1.1 cgd *
19 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
20 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
21 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
22 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
23 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
24 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
25 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
26 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
27 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
28 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
29 1.1 cgd * SUCH DAMAGE.
30 1.1 cgd *
31 1.25 fvdl * @(#)fifo_vnops.c 8.10 (Berkeley) 5/27/95
32 1.1 cgd */
33 1.32 lukem
34 1.32 lukem #include <sys/cdefs.h>
35 1.49 jonathan __KERNEL_RCSID(0, "$NetBSD: fifo_vnops.c,v 1.49 2004/05/22 22:52:14 jonathan Exp $");
36 1.1 cgd
37 1.6 mycroft #include <sys/param.h>
38 1.25 fvdl #include <sys/systm.h>
39 1.8 mycroft #include <sys/proc.h>
40 1.6 mycroft #include <sys/time.h>
41 1.6 mycroft #include <sys/namei.h>
42 1.6 mycroft #include <sys/vnode.h>
43 1.6 mycroft #include <sys/socket.h>
44 1.45 matt #include <sys/protosw.h>
45 1.6 mycroft #include <sys/socketvar.h>
46 1.6 mycroft #include <sys/stat.h>
47 1.6 mycroft #include <sys/ioctl.h>
48 1.6 mycroft #include <sys/file.h>
49 1.6 mycroft #include <sys/errno.h>
50 1.6 mycroft #include <sys/malloc.h>
51 1.17 christos #include <sys/un.h>
52 1.20 mycroft #include <sys/poll.h>
53 1.36 jdolecek #include <sys/event.h>
54 1.19 mycroft
55 1.6 mycroft #include <miscfs/fifofs/fifo.h>
56 1.19 mycroft #include <miscfs/genfs/genfs.h>
57 1.1 cgd
58 1.1 cgd /*
59 1.1 cgd * This structure is associated with the FIFO vnode and stores
60 1.1 cgd * the state associated with the FIFO.
61 1.1 cgd */
62 1.1 cgd struct fifoinfo {
63 1.1 cgd struct socket *fi_readsock;
64 1.1 cgd struct socket *fi_writesock;
65 1.34 chs long fi_opencount;
66 1.1 cgd long fi_readers;
67 1.1 cgd long fi_writers;
68 1.1 cgd };
69 1.1 cgd
70 1.17 christos int (**fifo_vnodeop_p) __P((void *));
71 1.29 jdolecek const struct vnodeopv_entry_desc fifo_vnodeop_entries[] = {
72 1.8 mycroft { &vop_default_desc, vn_default_error },
73 1.8 mycroft { &vop_lookup_desc, fifo_lookup }, /* lookup */
74 1.8 mycroft { &vop_create_desc, fifo_create }, /* create */
75 1.8 mycroft { &vop_mknod_desc, fifo_mknod }, /* mknod */
76 1.8 mycroft { &vop_open_desc, fifo_open }, /* open */
77 1.8 mycroft { &vop_close_desc, fifo_close }, /* close */
78 1.8 mycroft { &vop_access_desc, fifo_access }, /* access */
79 1.8 mycroft { &vop_getattr_desc, fifo_getattr }, /* getattr */
80 1.8 mycroft { &vop_setattr_desc, fifo_setattr }, /* setattr */
81 1.8 mycroft { &vop_read_desc, fifo_read }, /* read */
82 1.8 mycroft { &vop_write_desc, fifo_write }, /* write */
83 1.13 mycroft { &vop_lease_desc, fifo_lease_check }, /* lease */
84 1.8 mycroft { &vop_ioctl_desc, fifo_ioctl }, /* ioctl */
85 1.20 mycroft { &vop_poll_desc, fifo_poll }, /* poll */
86 1.36 jdolecek { &vop_kqfilter_desc, fifo_kqfilter }, /* kqfilter */
87 1.25 fvdl { &vop_revoke_desc, fifo_revoke }, /* revoke */
88 1.8 mycroft { &vop_mmap_desc, fifo_mmap }, /* mmap */
89 1.8 mycroft { &vop_fsync_desc, fifo_fsync }, /* fsync */
90 1.8 mycroft { &vop_seek_desc, fifo_seek }, /* seek */
91 1.8 mycroft { &vop_remove_desc, fifo_remove }, /* remove */
92 1.8 mycroft { &vop_link_desc, fifo_link }, /* link */
93 1.8 mycroft { &vop_rename_desc, fifo_rename }, /* rename */
94 1.8 mycroft { &vop_mkdir_desc, fifo_mkdir }, /* mkdir */
95 1.8 mycroft { &vop_rmdir_desc, fifo_rmdir }, /* rmdir */
96 1.8 mycroft { &vop_symlink_desc, fifo_symlink }, /* symlink */
97 1.8 mycroft { &vop_readdir_desc, fifo_readdir }, /* readdir */
98 1.8 mycroft { &vop_readlink_desc, fifo_readlink }, /* readlink */
99 1.8 mycroft { &vop_abortop_desc, fifo_abortop }, /* abortop */
100 1.8 mycroft { &vop_inactive_desc, fifo_inactive }, /* inactive */
101 1.8 mycroft { &vop_reclaim_desc, fifo_reclaim }, /* reclaim */
102 1.8 mycroft { &vop_lock_desc, fifo_lock }, /* lock */
103 1.8 mycroft { &vop_unlock_desc, fifo_unlock }, /* unlock */
104 1.8 mycroft { &vop_bmap_desc, fifo_bmap }, /* bmap */
105 1.8 mycroft { &vop_strategy_desc, fifo_strategy }, /* strategy */
106 1.8 mycroft { &vop_print_desc, fifo_print }, /* print */
107 1.8 mycroft { &vop_islocked_desc, fifo_islocked }, /* islocked */
108 1.8 mycroft { &vop_pathconf_desc, fifo_pathconf }, /* pathconf */
109 1.8 mycroft { &vop_advlock_desc, fifo_advlock }, /* advlock */
110 1.8 mycroft { &vop_blkatoff_desc, fifo_blkatoff }, /* blkatoff */
111 1.8 mycroft { &vop_valloc_desc, fifo_valloc }, /* valloc */
112 1.8 mycroft { &vop_vfree_desc, fifo_vfree }, /* vfree */
113 1.8 mycroft { &vop_truncate_desc, fifo_truncate }, /* truncate */
114 1.8 mycroft { &vop_update_desc, fifo_update }, /* update */
115 1.8 mycroft { &vop_bwrite_desc, fifo_bwrite }, /* bwrite */
116 1.31 sommerfe { &vop_putpages_desc, fifo_putpages }, /* putpages */
117 1.17 christos { (struct vnodeop_desc*)NULL, (int(*) __P((void *)))NULL }
118 1.1 cgd };
119 1.29 jdolecek const struct vnodeopv_desc fifo_vnodeop_opv_desc =
120 1.8 mycroft { &fifo_vnodeop_p, fifo_vnodeop_entries };
121 1.1 cgd
122 1.1 cgd /*
123 1.1 cgd * Trivial lookup routine that always fails.
124 1.1 cgd */
125 1.1 cgd /* ARGSUSED */
126 1.17 christos int
127 1.30 lukem fifo_lookup(void *v)
128 1.17 christos {
129 1.8 mycroft struct vop_lookup_args /* {
130 1.30 lukem struct vnode *a_dvp;
131 1.30 lukem struct vnode **a_vpp;
132 1.30 lukem struct componentname *a_cnp;
133 1.17 christos } */ *ap = v;
134 1.8 mycroft
135 1.8 mycroft *ap->a_vpp = NULL;
136 1.1 cgd return (ENOTDIR);
137 1.1 cgd }
138 1.1 cgd
139 1.1 cgd /*
140 1.1 cgd * Open called to set up a new instance of a fifo or
141 1.1 cgd * to find an active instance of a fifo.
142 1.1 cgd */
143 1.1 cgd /* ARGSUSED */
144 1.17 christos int
145 1.30 lukem fifo_open(void *v)
146 1.17 christos {
147 1.8 mycroft struct vop_open_args /* {
148 1.30 lukem struct vnode *a_vp;
149 1.30 lukem int a_mode;
150 1.30 lukem struct ucred *a_cred;
151 1.41 fvdl struct proc *a_p;
152 1.17 christos } */ *ap = v;
153 1.30 lukem struct vnode *vp;
154 1.30 lukem struct fifoinfo *fip;
155 1.30 lukem struct proc *p;
156 1.30 lukem struct socket *rso, *wso;
157 1.30 lukem int error;
158 1.1 cgd
159 1.30 lukem vp = ap->a_vp;
160 1.41 fvdl p = ap->a_p;
161 1.30 lukem
162 1.1 cgd if ((fip = vp->v_fifoinfo) == NULL) {
163 1.1 cgd MALLOC(fip, struct fifoinfo *, sizeof(*fip), M_VNODE, M_WAITOK);
164 1.1 cgd vp->v_fifoinfo = fip;
165 1.49 jonathan error = socreate(AF_LOCAL, &rso, SOCK_STREAM, 0, p);
166 1.49 jonathan if (error != 0) {
167 1.1 cgd free(fip, M_VNODE);
168 1.1 cgd vp->v_fifoinfo = NULL;
169 1.1 cgd return (error);
170 1.1 cgd }
171 1.1 cgd fip->fi_readsock = rso;
172 1.49 jonathan error = socreate(AF_LOCAL, &wso, SOCK_STREAM, 0, p);
173 1.49 jonathan if (error != 0) {
174 1.1 cgd (void)soclose(rso);
175 1.1 cgd free(fip, M_VNODE);
176 1.1 cgd vp->v_fifoinfo = NULL;
177 1.1 cgd return (error);
178 1.1 cgd }
179 1.1 cgd fip->fi_writesock = wso;
180 1.45 matt if ((error = unp_connect2(wso, rso, PRU_CONNECT2)) != 0) {
181 1.1 cgd (void)soclose(wso);
182 1.1 cgd (void)soclose(rso);
183 1.1 cgd free(fip, M_VNODE);
184 1.1 cgd vp->v_fifoinfo = NULL;
185 1.1 cgd return (error);
186 1.1 cgd }
187 1.8 mycroft fip->fi_readers = fip->fi_writers = 0;
188 1.34 chs fip->fi_opencount = 0;
189 1.1 cgd wso->so_state |= SS_CANTRCVMORE;
190 1.1 cgd rso->so_state |= SS_CANTSENDMORE;
191 1.1 cgd }
192 1.34 chs fip->fi_opencount++;
193 1.8 mycroft if (ap->a_mode & FREAD) {
194 1.16 mycroft if (fip->fi_readers++ == 0) {
195 1.1 cgd fip->fi_writesock->so_state &= ~SS_CANTSENDMORE;
196 1.1 cgd if (fip->fi_writers > 0)
197 1.47 jrf wakeup(&fip->fi_writers);
198 1.1 cgd }
199 1.16 mycroft }
200 1.16 mycroft if (ap->a_mode & FWRITE) {
201 1.16 mycroft if (fip->fi_writers++ == 0) {
202 1.16 mycroft fip->fi_readsock->so_state &= ~SS_CANTRCVMORE;
203 1.16 mycroft if (fip->fi_readers > 0)
204 1.47 jrf wakeup(&fip->fi_readers);
205 1.2 cgd }
206 1.16 mycroft }
207 1.16 mycroft if (ap->a_mode & FREAD) {
208 1.16 mycroft if (ap->a_mode & O_NONBLOCK) {
209 1.1 cgd } else {
210 1.39 martin while (!soreadable(fip->fi_readsock) && fip->fi_writers == 0) {
211 1.25 fvdl VOP_UNLOCK(vp, 0);
212 1.47 jrf error = tsleep(&fip->fi_readers,
213 1.38 jdolecek PCATCH | PSOCK, "fifor", 0);
214 1.25 fvdl vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
215 1.16 mycroft if (error)
216 1.16 mycroft goto bad;
217 1.1 cgd }
218 1.16 mycroft }
219 1.16 mycroft }
220 1.16 mycroft if (ap->a_mode & FWRITE) {
221 1.16 mycroft if (ap->a_mode & O_NONBLOCK) {
222 1.16 mycroft if (fip->fi_readers == 0) {
223 1.16 mycroft error = ENXIO;
224 1.16 mycroft goto bad;
225 1.16 mycroft }
226 1.16 mycroft } else {
227 1.2 cgd while (fip->fi_readers == 0) {
228 1.25 fvdl VOP_UNLOCK(vp, 0);
229 1.47 jrf error = tsleep(&fip->fi_writers,
230 1.38 jdolecek PCATCH | PSOCK, "fifow", 0);
231 1.25 fvdl vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
232 1.8 mycroft if (error)
233 1.16 mycroft goto bad;
234 1.2 cgd }
235 1.1 cgd }
236 1.1 cgd }
237 1.16 mycroft return (0);
238 1.30 lukem bad:
239 1.41 fvdl VOP_CLOSE(vp, ap->a_mode, ap->a_cred, p);
240 1.1 cgd return (error);
241 1.1 cgd }
242 1.1 cgd
243 1.1 cgd /*
244 1.1 cgd * Vnode op for read
245 1.1 cgd */
246 1.1 cgd /* ARGSUSED */
247 1.17 christos int
248 1.30 lukem fifo_read(void *v)
249 1.17 christos {
250 1.8 mycroft struct vop_read_args /* {
251 1.30 lukem struct vnode *a_vp;
252 1.30 lukem struct uio *a_uio;
253 1.30 lukem int a_ioflag;
254 1.30 lukem struct ucred *a_cred;
255 1.17 christos } */ *ap = v;
256 1.30 lukem struct uio *uio;
257 1.30 lukem struct socket *rso;
258 1.35 thorpej int error;
259 1.35 thorpej size_t startresid;
260 1.1 cgd
261 1.30 lukem uio = ap->a_uio;
262 1.30 lukem rso = ap->a_vp->v_fifoinfo->fi_readsock;
263 1.1 cgd #ifdef DIAGNOSTIC
264 1.1 cgd if (uio->uio_rw != UIO_READ)
265 1.1 cgd panic("fifo_read mode");
266 1.1 cgd #endif
267 1.1 cgd if (uio->uio_resid == 0)
268 1.1 cgd return (0);
269 1.8 mycroft if (ap->a_ioflag & IO_NDELAY)
270 1.1 cgd rso->so_state |= SS_NBIO;
271 1.1 cgd startresid = uio->uio_resid;
272 1.25 fvdl VOP_UNLOCK(ap->a_vp, 0);
273 1.27 matt error = (*rso->so_receive)(rso, (struct mbuf **)0, uio,
274 1.27 matt (struct mbuf **)0, (struct mbuf **)0, (int *)0);
275 1.25 fvdl vn_lock(ap->a_vp, LK_EXCLUSIVE | LK_RETRY);
276 1.1 cgd /*
277 1.1 cgd * Clear EOF indication after first such return.
278 1.1 cgd */
279 1.1 cgd if (uio->uio_resid == startresid)
280 1.1 cgd rso->so_state &= ~SS_CANTRCVMORE;
281 1.23 kleink if (ap->a_ioflag & IO_NDELAY) {
282 1.1 cgd rso->so_state &= ~SS_NBIO;
283 1.23 kleink if (error == EWOULDBLOCK &&
284 1.23 kleink ap->a_vp->v_fifoinfo->fi_writers == 0)
285 1.23 kleink error = 0;
286 1.23 kleink }
287 1.1 cgd return (error);
288 1.1 cgd }
289 1.1 cgd
290 1.1 cgd /*
291 1.1 cgd * Vnode op for write
292 1.1 cgd */
293 1.1 cgd /* ARGSUSED */
294 1.17 christos int
295 1.30 lukem fifo_write(void *v)
296 1.17 christos {
297 1.8 mycroft struct vop_write_args /* {
298 1.30 lukem struct vnode *a_vp;
299 1.30 lukem struct uio *a_uio;
300 1.30 lukem int a_ioflag;
301 1.30 lukem struct ucred *a_cred;
302 1.17 christos } */ *ap = v;
303 1.30 lukem struct socket *wso;
304 1.30 lukem int error;
305 1.1 cgd
306 1.30 lukem wso = ap->a_vp->v_fifoinfo->fi_writesock;
307 1.1 cgd #ifdef DIAGNOSTIC
308 1.8 mycroft if (ap->a_uio->uio_rw != UIO_WRITE)
309 1.1 cgd panic("fifo_write mode");
310 1.1 cgd #endif
311 1.8 mycroft if (ap->a_ioflag & IO_NDELAY)
312 1.1 cgd wso->so_state |= SS_NBIO;
313 1.25 fvdl VOP_UNLOCK(ap->a_vp, 0);
314 1.27 matt error = (*wso->so_send)(wso, (struct mbuf *)0, ap->a_uio, 0,
315 1.49 jonathan (struct mbuf *)0, 0, curproc /*XXX*/);
316 1.25 fvdl vn_lock(ap->a_vp, LK_EXCLUSIVE | LK_RETRY);
317 1.8 mycroft if (ap->a_ioflag & IO_NDELAY)
318 1.1 cgd wso->so_state &= ~SS_NBIO;
319 1.1 cgd return (error);
320 1.1 cgd }
321 1.1 cgd
322 1.1 cgd /*
323 1.1 cgd * Device ioctl operation.
324 1.1 cgd */
325 1.1 cgd /* ARGSUSED */
326 1.17 christos int
327 1.30 lukem fifo_ioctl(void *v)
328 1.17 christos {
329 1.8 mycroft struct vop_ioctl_args /* {
330 1.30 lukem struct vnode *a_vp;
331 1.30 lukem u_long a_command;
332 1.48 jrf void *a_data;
333 1.30 lukem int a_fflag;
334 1.30 lukem struct ucred *a_cred;
335 1.41 fvdl struct proc *a_p;
336 1.17 christos } */ *ap = v;
337 1.30 lukem struct file filetmp;
338 1.30 lukem int error;
339 1.1 cgd
340 1.8 mycroft if (ap->a_command == FIONBIO)
341 1.1 cgd return (0);
342 1.16 mycroft if (ap->a_fflag & FREAD) {
343 1.48 jrf filetmp.f_data = ap->a_vp->v_fifoinfo->fi_readsock;
344 1.41 fvdl error = soo_ioctl(&filetmp, ap->a_command, ap->a_data, ap->a_p);
345 1.16 mycroft if (error)
346 1.16 mycroft return (error);
347 1.16 mycroft }
348 1.16 mycroft if (ap->a_fflag & FWRITE) {
349 1.48 jrf filetmp.f_data = ap->a_vp->v_fifoinfo->fi_writesock;
350 1.41 fvdl error = soo_ioctl(&filetmp, ap->a_command, ap->a_data, ap->a_p);
351 1.16 mycroft if (error)
352 1.16 mycroft return (error);
353 1.16 mycroft }
354 1.16 mycroft return (0);
355 1.1 cgd }
356 1.1 cgd
357 1.1 cgd /* ARGSUSED */
358 1.17 christos int
359 1.30 lukem fifo_poll(void *v)
360 1.17 christos {
361 1.20 mycroft struct vop_poll_args /* {
362 1.30 lukem struct vnode *a_vp;
363 1.30 lukem int a_events;
364 1.41 fvdl struct proc *a_p;
365 1.17 christos } */ *ap = v;
366 1.30 lukem struct file filetmp;
367 1.30 lukem int revents;
368 1.1 cgd
369 1.30 lukem revents = 0;
370 1.20 mycroft if (ap->a_events & (POLLIN | POLLPRI | POLLRDNORM | POLLRDBAND)) {
371 1.48 jrf filetmp.f_data = ap->a_vp->v_fifoinfo->fi_readsock;
372 1.20 mycroft if (filetmp.f_data)
373 1.41 fvdl revents |= soo_poll(&filetmp, ap->a_events, ap->a_p);
374 1.16 mycroft }
375 1.20 mycroft if (ap->a_events & (POLLOUT | POLLWRNORM | POLLWRBAND)) {
376 1.48 jrf filetmp.f_data = ap->a_vp->v_fifoinfo->fi_writesock;
377 1.20 mycroft if (filetmp.f_data)
378 1.41 fvdl revents |= soo_poll(&filetmp, ap->a_events, ap->a_p);
379 1.16 mycroft }
380 1.20 mycroft
381 1.20 mycroft return (revents);
382 1.1 cgd }
383 1.1 cgd
384 1.25 fvdl int
385 1.30 lukem fifo_inactive(void *v)
386 1.25 fvdl {
387 1.25 fvdl struct vop_inactive_args /* {
388 1.30 lukem struct vnode *a_vp;
389 1.41 fvdl struct proc *a_p;
390 1.25 fvdl } */ *ap = v;
391 1.25 fvdl
392 1.25 fvdl VOP_UNLOCK(ap->a_vp, 0);
393 1.25 fvdl return (0);
394 1.25 fvdl }
395 1.25 fvdl
396 1.1 cgd /*
397 1.1 cgd * This is a noop, simply returning what one has been given.
398 1.1 cgd */
399 1.17 christos int
400 1.30 lukem fifo_bmap(void *v)
401 1.17 christos {
402 1.8 mycroft struct vop_bmap_args /* {
403 1.30 lukem struct vnode *a_vp;
404 1.30 lukem daddr_t a_bn;
405 1.30 lukem struct vnode **a_vpp;
406 1.30 lukem daddr_t *a_bnp;
407 1.30 lukem int *a_runp;
408 1.17 christos } */ *ap = v;
409 1.1 cgd
410 1.8 mycroft if (ap->a_vpp != NULL)
411 1.8 mycroft *ap->a_vpp = ap->a_vp;
412 1.8 mycroft if (ap->a_bnp != NULL)
413 1.8 mycroft *ap->a_bnp = ap->a_bn;
414 1.25 fvdl if (ap->a_runp != NULL)
415 1.25 fvdl *ap->a_runp = 0;
416 1.1 cgd return (0);
417 1.1 cgd }
418 1.1 cgd
419 1.1 cgd /*
420 1.1 cgd * Device close routine
421 1.1 cgd */
422 1.1 cgd /* ARGSUSED */
423 1.17 christos int
424 1.30 lukem fifo_close(void *v)
425 1.17 christos {
426 1.8 mycroft struct vop_close_args /* {
427 1.30 lukem struct vnode *a_vp;
428 1.30 lukem int a_fflag;
429 1.30 lukem struct ucred *a_cred;
430 1.41 fvdl struct proc *a_p;
431 1.17 christos } */ *ap = v;
432 1.30 lukem struct vnode *vp;
433 1.30 lukem struct fifoinfo *fip;
434 1.1 cgd
435 1.30 lukem vp = ap->a_vp;
436 1.30 lukem fip = vp->v_fifoinfo;
437 1.16 mycroft if (ap->a_fflag & FREAD) {
438 1.16 mycroft if (--fip->fi_readers == 0)
439 1.16 mycroft socantsendmore(fip->fi_writesock);
440 1.16 mycroft }
441 1.8 mycroft if (ap->a_fflag & FWRITE) {
442 1.16 mycroft if (--fip->fi_writers == 0)
443 1.1 cgd socantrcvmore(fip->fi_readsock);
444 1.1 cgd }
445 1.46 wrstuden /*
446 1.46 wrstuden * shut down if either last close, or if close called from
447 1.46 wrstuden * vclean()
448 1.46 wrstuden */
449 1.46 wrstuden if ((--fip->fi_opencount == 0)
450 1.46 wrstuden || ((ap->a_fflag & (FREAD | FWRITE | FNONBLOCK)) == FNONBLOCK)) {
451 1.34 chs (void) soclose(fip->fi_readsock);
452 1.34 chs (void) soclose(fip->fi_writesock);
453 1.34 chs FREE(fip, M_VNODE);
454 1.34 chs vp->v_fifoinfo = NULL;
455 1.34 chs }
456 1.34 chs return (0);
457 1.1 cgd }
458 1.1 cgd
459 1.1 cgd /*
460 1.1 cgd * Print out the contents of a fifo vnode.
461 1.1 cgd */
462 1.17 christos int
463 1.30 lukem fifo_print(void *v)
464 1.17 christos {
465 1.8 mycroft struct vop_print_args /* {
466 1.30 lukem struct vnode *a_vp;
467 1.17 christos } */ *ap = v;
468 1.1 cgd
469 1.22 christos printf("tag VT_NON");
470 1.8 mycroft fifo_printinfo(ap->a_vp);
471 1.22 christos printf("\n");
472 1.17 christos return 0;
473 1.1 cgd }
474 1.1 cgd
475 1.1 cgd /*
476 1.1 cgd * Print out internal contents of a fifo vnode.
477 1.1 cgd */
478 1.17 christos void
479 1.30 lukem fifo_printinfo(struct vnode *vp)
480 1.1 cgd {
481 1.30 lukem struct fifoinfo *fip;
482 1.1 cgd
483 1.30 lukem fip = vp->v_fifoinfo;
484 1.22 christos printf(", fifo with %ld readers and %ld writers",
485 1.21 christos fip->fi_readers, fip->fi_writers);
486 1.1 cgd }
487 1.1 cgd
488 1.1 cgd /*
489 1.8 mycroft * Return POSIX pathconf information applicable to fifo's.
490 1.8 mycroft */
491 1.17 christos int
492 1.30 lukem fifo_pathconf(void *v)
493 1.17 christos {
494 1.8 mycroft struct vop_pathconf_args /* {
495 1.30 lukem struct vnode *a_vp;
496 1.30 lukem int a_name;
497 1.30 lukem register_t *a_retval;
498 1.17 christos } */ *ap = v;
499 1.8 mycroft
500 1.8 mycroft switch (ap->a_name) {
501 1.8 mycroft case _PC_LINK_MAX:
502 1.8 mycroft *ap->a_retval = LINK_MAX;
503 1.8 mycroft return (0);
504 1.8 mycroft case _PC_PIPE_BUF:
505 1.8 mycroft *ap->a_retval = PIPE_BUF;
506 1.8 mycroft return (0);
507 1.8 mycroft case _PC_CHOWN_RESTRICTED:
508 1.26 kleink *ap->a_retval = 1;
509 1.26 kleink return (0);
510 1.26 kleink case _PC_SYNC_IO:
511 1.8 mycroft *ap->a_retval = 1;
512 1.8 mycroft return (0);
513 1.8 mycroft default:
514 1.8 mycroft return (EINVAL);
515 1.8 mycroft }
516 1.1 cgd /* NOTREACHED */
517 1.36 jdolecek }
518 1.36 jdolecek
519 1.36 jdolecek static void
520 1.36 jdolecek filt_fifordetach(struct knote *kn)
521 1.36 jdolecek {
522 1.36 jdolecek struct socket *so;
523 1.36 jdolecek
524 1.36 jdolecek so = (struct socket *)kn->kn_hook;
525 1.37 christos SLIST_REMOVE(&so->so_rcv.sb_sel.sel_klist, kn, knote, kn_selnext);
526 1.37 christos if (SLIST_EMPTY(&so->so_rcv.sb_sel.sel_klist))
527 1.36 jdolecek so->so_rcv.sb_flags &= ~SB_KNOTE;
528 1.36 jdolecek }
529 1.36 jdolecek
530 1.36 jdolecek static int
531 1.36 jdolecek filt_fiforead(struct knote *kn, long hint)
532 1.36 jdolecek {
533 1.36 jdolecek struct socket *so;
534 1.36 jdolecek
535 1.36 jdolecek so = (struct socket *)kn->kn_hook;
536 1.36 jdolecek kn->kn_data = so->so_rcv.sb_cc;
537 1.36 jdolecek if (so->so_state & SS_CANTRCVMORE) {
538 1.36 jdolecek kn->kn_flags |= EV_EOF;
539 1.36 jdolecek return (1);
540 1.36 jdolecek }
541 1.36 jdolecek kn->kn_flags &= ~EV_EOF;
542 1.36 jdolecek return (kn->kn_data > 0);
543 1.36 jdolecek }
544 1.36 jdolecek
545 1.36 jdolecek static void
546 1.36 jdolecek filt_fifowdetach(struct knote *kn)
547 1.36 jdolecek {
548 1.36 jdolecek struct socket *so;
549 1.36 jdolecek
550 1.36 jdolecek so = (struct socket *)kn->kn_hook;
551 1.37 christos SLIST_REMOVE(&so->so_snd.sb_sel.sel_klist, kn, knote, kn_selnext);
552 1.37 christos if (SLIST_EMPTY(&so->so_snd.sb_sel.sel_klist))
553 1.36 jdolecek so->so_snd.sb_flags &= ~SB_KNOTE;
554 1.36 jdolecek }
555 1.36 jdolecek
556 1.36 jdolecek static int
557 1.36 jdolecek filt_fifowrite(struct knote *kn, long hint)
558 1.36 jdolecek {
559 1.36 jdolecek struct socket *so;
560 1.36 jdolecek
561 1.36 jdolecek so = (struct socket *)kn->kn_hook;
562 1.36 jdolecek kn->kn_data = sbspace(&so->so_snd);
563 1.36 jdolecek if (so->so_state & SS_CANTSENDMORE) {
564 1.36 jdolecek kn->kn_flags |= EV_EOF;
565 1.36 jdolecek return (1);
566 1.36 jdolecek }
567 1.36 jdolecek kn->kn_flags &= ~EV_EOF;
568 1.36 jdolecek return (kn->kn_data >= so->so_snd.sb_lowat);
569 1.36 jdolecek }
570 1.36 jdolecek
571 1.36 jdolecek static const struct filterops fiforead_filtops =
572 1.36 jdolecek { 1, NULL, filt_fifordetach, filt_fiforead };
573 1.36 jdolecek static const struct filterops fifowrite_filtops =
574 1.36 jdolecek { 1, NULL, filt_fifowdetach, filt_fifowrite };
575 1.36 jdolecek
576 1.36 jdolecek /* ARGSUSED */
577 1.36 jdolecek int
578 1.36 jdolecek fifo_kqfilter(void *v)
579 1.36 jdolecek {
580 1.36 jdolecek struct vop_kqfilter_args /* {
581 1.36 jdolecek struct vnode *a_vp;
582 1.36 jdolecek struct knote *a_kn;
583 1.36 jdolecek } */ *ap = v;
584 1.36 jdolecek struct socket *so;
585 1.36 jdolecek struct sockbuf *sb;
586 1.36 jdolecek
587 1.36 jdolecek so = (struct socket *)ap->a_vp->v_fifoinfo->fi_readsock;
588 1.36 jdolecek switch (ap->a_kn->kn_filter) {
589 1.36 jdolecek case EVFILT_READ:
590 1.36 jdolecek ap->a_kn->kn_fop = &fiforead_filtops;
591 1.36 jdolecek sb = &so->so_rcv;
592 1.36 jdolecek break;
593 1.36 jdolecek case EVFILT_WRITE:
594 1.36 jdolecek ap->a_kn->kn_fop = &fifowrite_filtops;
595 1.36 jdolecek sb = &so->so_snd;
596 1.36 jdolecek break;
597 1.36 jdolecek default:
598 1.36 jdolecek return (1);
599 1.36 jdolecek }
600 1.36 jdolecek
601 1.36 jdolecek ap->a_kn->kn_hook = so;
602 1.36 jdolecek
603 1.37 christos SLIST_INSERT_HEAD(&sb->sb_sel.sel_klist, ap->a_kn, kn_selnext);
604 1.36 jdolecek sb->sb_flags |= SB_KNOTE;
605 1.36 jdolecek return (0);
606 1.1 cgd }
607