diff options
| author | Niels Provos <provos@cvs.openbsd.org> | 2001-06-04 15:11:48 +0000 |
|---|---|---|
| committer | Niels Provos <provos@cvs.openbsd.org> | 2001-06-04 15:11:48 +0000 |
| commit | b1e0db2983b1b4fcb3b90c79bee0dad4dd080bd8 (patch) | |
| tree | e4ed75147845d3a641322295701891c9902c1fbf /sys | |
| parent | 6b10c48d5b91c11eddd20e93cec4bea00792b84b (diff) | |
make kqueue behave like select when testing for write instead of bailing
out.
Diffstat (limited to 'sys')
| -rw-r--r-- | sys/ufs/ufs/ufs_vnops.c | 25 |
1 files changed, 24 insertions, 1 deletions
diff --git a/sys/ufs/ufs/ufs_vnops.c b/sys/ufs/ufs/ufs_vnops.c index 30d2a3aa468..39384e09efe 100644 --- a/sys/ufs/ufs/ufs_vnops.c +++ b/sys/ufs/ufs/ufs_vnops.c @@ -1,4 +1,4 @@ -/* $OpenBSD: ufs_vnops.c,v 1.31 2001/04/25 21:31:17 csapuntz Exp $ */ +/* $OpenBSD: ufs_vnops.c,v 1.32 2001/06/04 15:11:47 provos Exp $ */ /* $NetBSD: ufs_vnops.c,v 1.18 1996/05/11 18:28:04 mycroft Exp $ */ /* @@ -78,6 +78,7 @@ static int ufs_chmod __P((struct vnode *, int, struct ucred *, struct proc *)); static int ufs_chown __P((struct vnode *, uid_t, gid_t, struct ucred *, struct proc *)); int filt_ufsread __P((struct knote *kn, long hint)); +int filt_ufswrite __P((struct knote *kn, long hint)); int filt_ufsvnode __P((struct knote *kn, long hint)); void filt_ufsdetach __P((struct knote *kn)); @@ -2210,6 +2211,8 @@ bad: struct filterops ufsread_filtops = { 1, NULL, filt_ufsdetach, filt_ufsread }; +struct filterops ufswrite_filtops = + { 1, NULL, filt_ufsdetach, filt_ufswrite }; struct filterops ufsvnode_filtops = { 1, NULL, filt_ufsdetach, filt_ufsvnode }; @@ -2228,6 +2231,9 @@ ufs_kqfilter(v) case EVFILT_READ: kn->kn_fop = &ufsread_filtops; break; + case EVFILT_WRITE: + kn->kn_fop = &ufswrite_filtops; + break; case EVFILT_VNODE: kn->kn_fop = &ufsvnode_filtops; break; @@ -2275,6 +2281,23 @@ filt_ufsread(struct knote *kn, long hint) return (kn->kn_data != 0); } + +int +filt_ufswrite(struct knote *kn, long hint) +{ + /* + * filesystem is gone, so set the EOF flag and schedule + * the knote for deletion. + */ + if (hint == NOTE_REVOKE) { + kn->kn_flags |= (EV_EOF | EV_ONESHOT); + return (1); + } + + kn->kn_data = 0; + return (1); +} + int filt_ufsvnode(struct knote *kn, long hint) { |