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