Commit | Line | Data |
---|---|---|
da7c5cc6 | 1 | /* |
d9f5f868 | 2 | * Copyright (c) 1986, 1989, 1991 Regents of the University of California. |
7188ac27 | 3 | * All rights reserved. |
da7c5cc6 | 4 | * |
b702c21d | 5 | * %sccs.include.redist.c% |
7188ac27 | 6 | * |
2a431922 | 7 | * @(#)lfs_vnops.c 7.95 (Berkeley) %G% |
da7c5cc6 | 8 | */ |
6459ebe0 | 9 | |
c7e94c3a KB |
10 | #include <sys/param.h> |
11 | #include <sys/systm.h> | |
12 | #include <sys/namei.h> | |
13 | #include <sys/resourcevar.h> | |
14 | #include <sys/kernel.h> | |
15 | #include <sys/file.h> | |
16 | #include <sys/stat.h> | |
17 | #include <sys/buf.h> | |
18 | #include <sys/proc.h> | |
19 | #include <sys/conf.h> | |
20 | #include <sys/mount.h> | |
21 | #include <sys/vnode.h> | |
c7e94c3a KB |
22 | #include <sys/malloc.h> |
23 | ||
80e9de4e KM |
24 | #include <vm/vm.h> |
25 | ||
cb38190d KB |
26 | #include <miscfs/specfs/specdev.h> |
27 | #include <miscfs/fifofs/fifo.h> | |
28 | ||
d9f5f868 KB |
29 | #include <ufs/ufs/quota.h> |
30 | #include <ufs/ufs/inode.h> | |
31 | #include <ufs/ufs/dir.h> | |
17135473 | 32 | #include <ufs/ufs/ufsmount.h> |
d9f5f868 | 33 | #include <ufs/ufs/ufs_extern.h> |
c7e94c3a | 34 | |
d9f5f868 KB |
35 | #include <ufs/lfs/lfs.h> |
36 | #include <ufs/lfs/lfs_extern.h> | |
c7e94c3a KB |
37 | |
38 | /* Global vfs data structures for lfs. */ | |
9342689a JH |
39 | int (**lfs_vnodeop_p)(); |
40 | struct vnodeopv_entry_desc lfs_vnodeop_entries[] = { | |
41 | { &vop_default_desc, vn_default_error }, | |
42 | { &vop_lookup_desc, ufs_lookup }, /* lookup */ | |
3ce71481 KB |
43 | { &vop_create_desc, lfs_create }, /* create */ |
44 | { &vop_mknod_desc, lfs_mknod }, /* mknod */ | |
56253a3b | 45 | { &vop_open_desc, ufs_open }, /* open */ |
e5b88c97 | 46 | { &vop_close_desc, lfs_close }, /* close */ |
9342689a | 47 | { &vop_access_desc, ufs_access }, /* access */ |
17135473 | 48 | { &vop_getattr_desc, lfs_getattr }, /* getattr */ |
9342689a | 49 | { &vop_setattr_desc, ufs_setattr }, /* setattr */ |
56253a3b KM |
50 | { &vop_read_desc, lfs_read }, /* read */ |
51 | { &vop_write_desc, lfs_write }, /* write */ | |
52 | { &vop_ioctl_desc, ufs_ioctl }, /* ioctl */ | |
9342689a | 53 | { &vop_select_desc, ufs_select }, /* select */ |
56253a3b KM |
54 | { &vop_mmap_desc, ufs_mmap }, /* mmap */ |
55 | { &vop_fsync_desc, lfs_fsync }, /* fsync */ | |
56 | { &vop_seek_desc, ufs_seek }, /* seek */ | |
3ce71481 KB |
57 | { &vop_remove_desc, lfs_remove }, /* remove */ |
58 | { &vop_link_desc, lfs_link }, /* link */ | |
59 | { &vop_rename_desc, lfs_rename }, /* rename */ | |
60 | { &vop_mkdir_desc, lfs_mkdir }, /* mkdir */ | |
61 | { &vop_rmdir_desc, lfs_rmdir }, /* rmdir */ | |
62 | { &vop_symlink_desc, lfs_symlink }, /* symlink */ | |
9342689a JH |
63 | { &vop_readdir_desc, ufs_readdir }, /* readdir */ |
64 | { &vop_readlink_desc, ufs_readlink }, /* readlink */ | |
65 | { &vop_abortop_desc, ufs_abortop }, /* abortop */ | |
66 | { &vop_inactive_desc, lfs_inactive }, /* inactive */ | |
67 | { &vop_reclaim_desc, ufs_reclaim }, /* reclaim */ | |
56253a3b | 68 | { &vop_lock_desc, ufs_lock }, /* lock */ |
9342689a | 69 | { &vop_unlock_desc, ufs_unlock }, /* unlock */ |
2a431922 | 70 | { &vop_bmap_desc, ufs_bmap }, /* bmap */ |
9342689a | 71 | { &vop_strategy_desc, ufs_strategy }, /* strategy */ |
56253a3b | 72 | { &vop_print_desc, ufs_print }, /* print */ |
9342689a JH |
73 | { &vop_islocked_desc, ufs_islocked }, /* islocked */ |
74 | { &vop_advlock_desc, ufs_advlock }, /* advlock */ | |
75 | { &vop_blkatoff_desc, lfs_blkatoff }, /* blkatoff */ | |
9342689a | 76 | { &vop_valloc_desc, lfs_valloc }, /* valloc */ |
56253a3b | 77 | { &vop_vfree_desc, lfs_vfree }, /* vfree */ |
9342689a JH |
78 | { &vop_truncate_desc, lfs_truncate }, /* truncate */ |
79 | { &vop_update_desc, lfs_update }, /* update */ | |
80 | { &vop_bwrite_desc, lfs_bwrite }, /* bwrite */ | |
81 | { (struct vnodeop_desc*)NULL, (int(*)())NULL } | |
c7e94c3a | 82 | }; |
9342689a JH |
83 | struct vnodeopv_desc lfs_vnodeop_opv_desc = |
84 | { &lfs_vnodeop_p, lfs_vnodeop_entries }; | |
528f664c | 85 | |
9342689a JH |
86 | int (**lfs_specop_p)(); |
87 | struct vnodeopv_entry_desc lfs_specop_entries[] = { | |
88 | { &vop_default_desc, vn_default_error }, | |
89 | { &vop_lookup_desc, spec_lookup }, /* lookup */ | |
90 | { &vop_create_desc, spec_create }, /* create */ | |
91 | { &vop_mknod_desc, spec_mknod }, /* mknod */ | |
56253a3b | 92 | { &vop_open_desc, spec_open }, /* open */ |
9342689a JH |
93 | { &vop_close_desc, ufsspec_close }, /* close */ |
94 | { &vop_access_desc, ufs_access }, /* access */ | |
17135473 | 95 | { &vop_getattr_desc, lfs_getattr }, /* getattr */ |
9342689a JH |
96 | { &vop_setattr_desc, ufs_setattr }, /* setattr */ |
97 | { &vop_read_desc, ufsspec_read }, /* read */ | |
98 | { &vop_write_desc, ufsspec_write }, /* write */ | |
99 | { &vop_ioctl_desc, spec_ioctl }, /* ioctl */ | |
100 | { &vop_select_desc, spec_select }, /* select */ | |
56253a3b | 101 | { &vop_mmap_desc, spec_mmap }, /* mmap */ |
9342689a | 102 | { &vop_fsync_desc, spec_fsync }, /* fsync */ |
56253a3b | 103 | { &vop_seek_desc, spec_seek }, /* seek */ |
9342689a | 104 | { &vop_remove_desc, spec_remove }, /* remove */ |
56253a3b | 105 | { &vop_link_desc, spec_link }, /* link */ |
9342689a JH |
106 | { &vop_rename_desc, spec_rename }, /* rename */ |
107 | { &vop_mkdir_desc, spec_mkdir }, /* mkdir */ | |
108 | { &vop_rmdir_desc, spec_rmdir }, /* rmdir */ | |
109 | { &vop_symlink_desc, spec_symlink }, /* symlink */ | |
110 | { &vop_readdir_desc, spec_readdir }, /* readdir */ | |
111 | { &vop_readlink_desc, spec_readlink }, /* readlink */ | |
112 | { &vop_abortop_desc, spec_abortop }, /* abortop */ | |
113 | { &vop_inactive_desc, lfs_inactive }, /* inactive */ | |
114 | { &vop_reclaim_desc, ufs_reclaim }, /* reclaim */ | |
56253a3b | 115 | { &vop_lock_desc, ufs_lock }, /* lock */ |
9342689a | 116 | { &vop_unlock_desc, ufs_unlock }, /* unlock */ |
56253a3b | 117 | { &vop_bmap_desc, spec_bmap }, /* bmap */ |
9342689a | 118 | { &vop_strategy_desc, spec_strategy }, /* strategy */ |
56253a3b | 119 | { &vop_print_desc, ufs_print }, /* print */ |
9342689a JH |
120 | { &vop_islocked_desc, ufs_islocked }, /* islocked */ |
121 | { &vop_advlock_desc, spec_advlock }, /* advlock */ | |
122 | { &vop_blkatoff_desc, spec_blkatoff }, /* blkatoff */ | |
9342689a | 123 | { &vop_valloc_desc, spec_valloc }, /* valloc */ |
56253a3b | 124 | { &vop_vfree_desc, lfs_vfree }, /* vfree */ |
9342689a JH |
125 | { &vop_truncate_desc, spec_truncate }, /* truncate */ |
126 | { &vop_update_desc, lfs_update }, /* update */ | |
127 | { &vop_bwrite_desc, lfs_bwrite }, /* bwrite */ | |
128 | { (struct vnodeop_desc*)NULL, (int(*)())NULL } | |
a2d9885d | 129 | }; |
9342689a JH |
130 | struct vnodeopv_desc lfs_specop_opv_desc = |
131 | { &lfs_specop_p, lfs_specop_entries }; | |
a2d9885d KM |
132 | |
133 | #ifdef FIFO | |
9342689a JH |
134 | int (**lfs_fifoop_p)(); |
135 | struct vnodeopv_entry_desc lfs_fifoop_entries[] = { | |
136 | { &vop_default_desc, vn_default_error }, | |
137 | { &vop_lookup_desc, fifo_lookup }, /* lookup */ | |
138 | { &vop_create_desc, fifo_create }, /* create */ | |
139 | { &vop_mknod_desc, fifo_mknod }, /* mknod */ | |
56253a3b | 140 | { &vop_open_desc, fifo_open }, /* open */ |
9342689a JH |
141 | { &vop_close_desc, ufsfifo_close }, /* close */ |
142 | { &vop_access_desc, ufs_access }, /* access */ | |
17135473 | 143 | { &vop_getattr_desc, lfs_getattr }, /* getattr */ |
9342689a JH |
144 | { &vop_setattr_desc, ufs_setattr }, /* setattr */ |
145 | { &vop_read_desc, ufsfifo_read }, /* read */ | |
146 | { &vop_write_desc, ufsfifo_write }, /* write */ | |
147 | { &vop_ioctl_desc, fifo_ioctl }, /* ioctl */ | |
148 | { &vop_select_desc, fifo_select }, /* select */ | |
56253a3b | 149 | { &vop_mmap_desc, fifo_mmap }, /* mmap */ |
9342689a | 150 | { &vop_fsync_desc, fifo_fsync }, /* fsync */ |
56253a3b | 151 | { &vop_seek_desc, fifo_seek }, /* seek */ |
9342689a | 152 | { &vop_remove_desc, fifo_remove }, /* remove */ |
56253a3b | 153 | { &vop_link_desc, fifo_link }, /* link */ |
9342689a JH |
154 | { &vop_rename_desc, fifo_rename }, /* rename */ |
155 | { &vop_mkdir_desc, fifo_mkdir }, /* mkdir */ | |
156 | { &vop_rmdir_desc, fifo_rmdir }, /* rmdir */ | |
157 | { &vop_symlink_desc, fifo_symlink }, /* symlink */ | |
158 | { &vop_readdir_desc, fifo_readdir }, /* readdir */ | |
159 | { &vop_readlink_desc, fifo_readlink }, /* readlink */ | |
160 | { &vop_abortop_desc, fifo_abortop }, /* abortop */ | |
161 | { &vop_inactive_desc, lfs_inactive }, /* inactive */ | |
162 | { &vop_reclaim_desc, ufs_reclaim }, /* reclaim */ | |
56253a3b | 163 | { &vop_lock_desc, ufs_lock }, /* lock */ |
9342689a | 164 | { &vop_unlock_desc, ufs_unlock }, /* unlock */ |
56253a3b | 165 | { &vop_bmap_desc, fifo_bmap }, /* bmap */ |
9342689a | 166 | { &vop_strategy_desc, fifo_strategy }, /* strategy */ |
56253a3b | 167 | { &vop_print_desc, ufs_print }, /* print */ |
9342689a JH |
168 | { &vop_islocked_desc, ufs_islocked }, /* islocked */ |
169 | { &vop_advlock_desc, fifo_advlock }, /* advlock */ | |
170 | { &vop_blkatoff_desc, fifo_blkatoff }, /* blkatoff */ | |
9342689a | 171 | { &vop_valloc_desc, fifo_valloc }, /* valloc */ |
56253a3b | 172 | { &vop_vfree_desc, lfs_vfree }, /* vfree */ |
9342689a JH |
173 | { &vop_truncate_desc, fifo_truncate }, /* truncate */ |
174 | { &vop_update_desc, lfs_update }, /* update */ | |
175 | { &vop_bwrite_desc, lfs_bwrite }, /* bwrite */ | |
176 | { (struct vnodeop_desc*)NULL, (int(*)())NULL } | |
a2d9885d | 177 | }; |
9342689a JH |
178 | struct vnodeopv_desc lfs_fifoop_opv_desc = |
179 | { &lfs_fifoop_p, lfs_fifoop_entries }; | |
a2d9885d KM |
180 | #endif /* FIFO */ |
181 | ||
b373e060 KM |
182 | /* |
183 | * Vnode op for reading. | |
184 | */ | |
185 | /* ARGSUSED */ | |
56253a3b | 186 | lfs_read(ap) |
8d50beca KB |
187 | struct vop_read_args /* { |
188 | struct vnode *a_vp; | |
189 | struct uio *a_uio; | |
190 | int a_ioflag; | |
191 | struct ucred *a_cred; | |
192 | } */ *ap; | |
b373e060 | 193 | { |
cb38190d KB |
194 | register struct vnode *vp = ap->a_vp; |
195 | register struct inode *ip = VTOI(vp); | |
406c9a0d | 196 | register struct uio *uio = ap->a_uio; |
cb38190d | 197 | register struct lfs *fs; |
6873eea8 | 198 | struct buf *bp1, *bp2; |
b373e060 | 199 | daddr_t lbn, bn, rablock; |
0308fc84 | 200 | off_t diff; |
2a431922 | 201 | int error = 0, lock_on_enter, size; |
cb38190d | 202 | long n, on; |
b373e060 | 203 | |
5b169cb7 | 204 | #ifdef DIAGNOSTIC |
cb38190d | 205 | int type; |
406c9a0d | 206 | if (uio->uio_rw != UIO_READ) |
cb38190d | 207 | panic("lfs_read mode"); |
b373e060 KM |
208 | type = ip->i_mode & IFMT; |
209 | if (type != IFDIR && type != IFREG && type != IFLNK) | |
cb38190d KB |
210 | panic("lfs_read type"); |
211 | if (type == IFLNK && (int)ip->i_size < vp->v_mount->mnt_maxsymlinklen) | |
212 | panic("read short symlink"); | |
5b169cb7 | 213 | #endif |
406c9a0d | 214 | if (uio->uio_resid == 0) |
b373e060 | 215 | return (0); |
cb38190d KB |
216 | fs = ip->i_lfs; |
217 | if (uio->uio_offset < 0 || | |
218 | (u_quad_t)uio->uio_offset + uio->uio_resid > fs->lfs_maxfilesize) | |
219 | return (EFBIG); | |
b373e060 | 220 | ip->i_flag |= IACC; |
6873eea8 | 221 | bp1 = bp2 = NULL; |
2a431922 MS |
222 | if (lock_on_enter = ip->i_flag & ILOCKED) |
223 | IUNLOCK(ip); | |
b373e060 | 224 | do { |
406c9a0d JH |
225 | lbn = lblkno(fs, uio->uio_offset); |
226 | on = blkoff(fs, uio->uio_offset); | |
cb38190d | 227 | n = min((unsigned)(fs->lfs_bsize - on), uio->uio_resid); |
406c9a0d | 228 | diff = ip->i_size - uio->uio_offset; |
b373e060 | 229 | if (diff <= 0) |
6873eea8 | 230 | break; |
b373e060 KM |
231 | if (diff < n) |
232 | n = diff; | |
cb38190d | 233 | size = blksize(fs); |
17135473 | 234 | lfs_check(vp, lbn); |
2a431922 MS |
235 | /* */ |
236 | rablock = lbn + 1; | |
cb38190d | 237 | if (vp->v_lastr + 1 == lbn && |
20aa076b | 238 | lblktosize(fs, rablock) < ip->i_size) |
38f21582 | 239 | error = breadn(ITOV(ip), lbn, size, &rablock, |
6873eea8 | 240 | &size, 1, NOCRED, &bp1); |
b373e060 | 241 | else |
6873eea8 | 242 | error = bread(ITOV(ip), lbn, size, NOCRED, &bp1); |
2a431922 MS |
243 | /* |
244 | error = ufs_breada(vp, lbn, size, NOCRED, &bp1); | |
245 | */ | |
6873eea8 KB |
246 | if (bp2) |
247 | brelse(bp2); | |
248 | bp2 = bp1; | |
cb38190d | 249 | vp->v_lastr = lbn; |
6873eea8 KB |
250 | n = min(n, size - bp2->b_resid); |
251 | if (error) | |
252 | break; | |
253 | error = uiomove(bp2->b_un.b_addr + on, (int)n, uio); | |
406c9a0d | 254 | if (n + on == fs->lfs_bsize || uio->uio_offset == ip->i_size) |
6873eea8 | 255 | bp2->b_flags |= B_AGE; |
406c9a0d | 256 | } while (error == 0 && uio->uio_resid > 0 && n != 0); |
6873eea8 KB |
257 | if (bp2) |
258 | brelse(bp2); | |
2a431922 MS |
259 | if (lock_on_enter) |
260 | ILOCK(ip); | |
b373e060 KM |
261 | return (error); |
262 | } | |
263 | ||
264 | /* | |
265 | * Vnode op for writing. | |
266 | */ | |
56253a3b | 267 | lfs_write(ap) |
8d50beca KB |
268 | struct vop_write_args /* { |
269 | struct vnode *a_vp; | |
270 | struct uio *a_uio; | |
271 | int a_ioflag; | |
272 | struct ucred *a_cred; | |
273 | } */ *ap; | |
b373e060 | 274 | { |
406c9a0d | 275 | register struct vnode *vp = ap->a_vp; |
56253a3b KM |
276 | register struct uio *uio = ap->a_uio; |
277 | struct proc *p = uio->uio_procp; | |
406c9a0d | 278 | register struct inode *ip = VTOI(vp); |
a418dc41 | 279 | register struct lfs *fs; |
56253a3b | 280 | register ioflag = ap->a_ioflag; |
d942bf69 | 281 | struct timeval tv; |
6873eea8 | 282 | struct buf *bp1, *bp2; |
a418dc41 | 283 | daddr_t lbn; |
0308fc84 | 284 | off_t osize; |
a418dc41 | 285 | int n, on, flags, newblock; |
8986c97c | 286 | int size, resid, error = 0; |
b373e060 | 287 | |
5b169cb7 | 288 | #ifdef DIAGNOSTIC |
56253a3b | 289 | if (uio->uio_rw != UIO_WRITE) |
a418dc41 | 290 | panic("lfs_write mode"); |
5b169cb7 | 291 | #endif |
406c9a0d | 292 | switch (vp->v_type) { |
b373e060 | 293 | case VREG: |
56253a3b KM |
294 | if (ioflag & IO_APPEND) |
295 | uio->uio_offset = ip->i_size; | |
b373e060 KM |
296 | /* fall through */ |
297 | case VLNK: | |
298 | break; | |
299 | ||
300 | case VDIR: | |
a418dc41 | 301 | /* XXX This may not be correct for LFS. */ |
56253a3b | 302 | if ((ioflag & IO_SYNC) == 0) |
a418dc41 | 303 | panic("lfs_write nonsync dir write"); |
b373e060 KM |
304 | break; |
305 | ||
306 | default: | |
a418dc41 | 307 | panic("lfs_write type"); |
b373e060 | 308 | } |
56253a3b | 309 | if (uio->uio_offset < 0) |
b373e060 | 310 | return (EINVAL); |
56253a3b | 311 | if (uio->uio_resid == 0) |
b373e060 KM |
312 | return (0); |
313 | /* | |
314 | * Maybe this should be above the vnode op call, but so long as | |
315 | * file servers have no limits, i don't think it matters | |
316 | */ | |
406c9a0d | 317 | if (vp->v_type == VREG && p && |
56253a3b | 318 | uio->uio_offset + uio->uio_resid > |
c6f5111d MK |
319 | p->p_rlimit[RLIMIT_FSIZE].rlim_cur) { |
320 | psignal(p, SIGXFSZ); | |
b373e060 KM |
321 | return (EFBIG); |
322 | } | |
56253a3b | 323 | resid = uio->uio_resid; |
b373e060 | 324 | osize = ip->i_size; |
d5075120 | 325 | fs = ip->i_lfs; /* LFS */ |
cb38190d KB |
326 | if (uio->uio_offset < 0 || |
327 | (u_quad_t)uio->uio_offset + uio->uio_resid > fs->lfs_maxfilesize) | |
328 | return (EFBIG); | |
6873eea8 KB |
329 | |
330 | /* | |
331 | * XXX | |
332 | * FFS uses the VOP_LOCK to provide serializability of multi-block | |
333 | * reads and writes. Since the cleaner may need to interrupt and | |
334 | * clean a vnode, this isn't such a good idea for us. We use | |
335 | * ordered locking instead. Hold buffer N busy until buffer N+1 | |
336 | * has been obtained. We get much better concurrency that way. | |
337 | */ | |
338 | bp1 = bp2 = NULL; | |
339 | IUNLOCK(ip); | |
b373e060 | 340 | do { |
56253a3b KM |
341 | lbn = lblkno(fs, uio->uio_offset); |
342 | on = blkoff(fs, uio->uio_offset); | |
cb38190d | 343 | n = min((unsigned)(fs->lfs_bsize - on), uio->uio_resid); |
17135473 | 344 | lfs_check(vp, lbn); |
6873eea8 KB |
345 | if (error = lfs_balloc(vp, n, lbn, &bp1)) |
346 | break; | |
347 | if (bp2) | |
348 | error = VOP_BWRITE(bp2); | |
349 | bp2 = NULL; | |
350 | if (error) | |
b373e060 | 351 | break; |
56253a3b KM |
352 | if (uio->uio_offset + n > ip->i_size) { |
353 | ip->i_size = uio->uio_offset + n; | |
406c9a0d | 354 | vnode_pager_setsize(vp, (u_long)ip->i_size); |
8986c97c | 355 | } |
d5075120 | 356 | size = blksize(fs); |
406c9a0d | 357 | (void) vnode_pager_uncache(vp); |
6873eea8 KB |
358 | n = min(n, size - bp1->b_resid); |
359 | error = uiomove(bp1->b_un.b_addr + on, n, uio); | |
360 | /* XXX Why is this in the loop? */ | |
e1b76915 | 361 | if (ap->a_cred->cr_uid != 0) |
b373e060 | 362 | ip->i_mode &= ~(ISUID|ISGID); |
6873eea8 KB |
363 | bp2 = bp1; |
364 | bp1 = NULL; | |
56253a3b | 365 | } while (error == 0 && uio->uio_resid > 0 && n != 0); |
6873eea8 KB |
366 | if (bp1) |
367 | brelse(bp1); | |
368 | if (bp2) | |
369 | error = VOP_BWRITE(bp2); | |
370 | ||
17135473 KB |
371 | if (error) { |
372 | if (ioflag & IO_UNIT) { | |
373 | (void)VOP_TRUNCATE(vp, osize, ioflag & IO_SYNC, | |
374 | ap->a_cred, uio->uio_procp); | |
375 | uio->uio_offset -= resid - uio->uio_resid; | |
376 | uio->uio_resid = resid; | |
377 | } | |
6873eea8 KB |
378 | } |
379 | ||
d942bf69 KM |
380 | if (!error && (ioflag & IO_SYNC)) { |
381 | tv = time; | |
17135473 KB |
382 | if (!(error = VOP_UPDATE(vp, &tv, &tv, 1))) |
383 | error = VOP_FSYNC(vp, ap->a_cred, MNT_WAIT, | |
384 | uio->uio_procp); | |
d942bf69 | 385 | } |
6873eea8 | 386 | ILOCK(ip); |
b373e060 KM |
387 | return (error); |
388 | } | |
389 | ||
4f083fd7 | 390 | /* |
7188ac27 | 391 | * Synch an open file. |
4f083fd7 | 392 | */ |
7188ac27 | 393 | /* ARGSUSED */ |
56253a3b | 394 | lfs_fsync(ap) |
8d50beca KB |
395 | struct vop_fsync_args /* { |
396 | struct vnode *a_vp; | |
397 | struct ucred *a_cred; | |
398 | int a_waitfor; | |
399 | struct proc *a_p; | |
400 | } */ *ap; | |
528f664c | 401 | { |
d942bf69 | 402 | struct timeval tv; |
7188ac27 | 403 | |
d942bf69 | 404 | tv = time; |
774279ac KB |
405 | return (VOP_UPDATE(ap->a_vp, &tv, &tv, |
406 | ap->a_waitfor == MNT_WAIT ? LFS_SYNC : 0)); | |
88a7a62a | 407 | } |
a2d9885d KM |
408 | |
409 | /* | |
410 | * Last reference to an inode, write the inode out and if necessary, | |
411 | * truncate and deallocate the file. | |
412 | */ | |
413 | int | |
56253a3b | 414 | lfs_inactive(ap) |
8d50beca KB |
415 | struct vop_inactive_args /* { |
416 | struct vnode *a_vp; | |
417 | } */ *ap; | |
a2d9885d | 418 | { |
c6a63814 | 419 | extern int prtactive; |
56253a3b | 420 | register struct vnode *vp = ap->a_vp; |
a2d9885d | 421 | register struct inode *ip; |
d942bf69 | 422 | struct timeval tv; |
a2d9885d | 423 | int mode, error; |
a2d9885d | 424 | |
56253a3b KM |
425 | if (prtactive && vp->v_usecount != 0) |
426 | vprint("lfs_inactive: pushing active", vp); | |
a2d9885d KM |
427 | |
428 | /* Get rid of inodes related to stale file handles. */ | |
56253a3b | 429 | ip = VTOI(vp); |
a2d9885d | 430 | if (ip->i_mode == 0) { |
56253a3b KM |
431 | if ((vp->v_flag & VXLOCK) == 0) |
432 | vgone(vp); | |
a2d9885d KM |
433 | return (0); |
434 | } | |
435 | ||
436 | error = 0; | |
437 | ILOCK(ip); | |
56253a3b | 438 | if (ip->i_nlink <= 0 && (vp->v_mount->mnt_flag & MNT_RDONLY) == 0) { |
a2d9885d KM |
439 | #ifdef QUOTA |
440 | if (!getinoquota(ip)) | |
441 | (void)chkiq(ip, -1, NOCRED, 0); | |
442 | #endif | |
8d50beca | 443 | error = VOP_TRUNCATE(vp, (off_t)0, 0, NOCRED, NULL); |
a2d9885d KM |
444 | mode = ip->i_mode; |
445 | ip->i_mode = 0; | |
446 | ip->i_rdev = 0; | |
447 | ip->i_flag |= IUPD|ICHG; | |
56253a3b | 448 | VOP_VFREE(vp, ip->i_number, mode); |
a2d9885d | 449 | } |
d942bf69 KM |
450 | if (ip->i_flag&(IUPD|IACC|ICHG|IMOD)) { |
451 | tv = time; | |
452 | VOP_UPDATE(vp, &tv, &tv, 0); | |
453 | } | |
a2d9885d | 454 | IUNLOCK(ip); |
a2d9885d KM |
455 | /* |
456 | * If we are done with the inode, reclaim it | |
457 | * so that it can be reused immediately. | |
458 | */ | |
56253a3b KM |
459 | if (vp->v_usecount == 0 && ip->i_mode == 0) |
460 | vgone(vp); | |
a2d9885d KM |
461 | return (error); |
462 | } | |
3ce71481 KB |
463 | |
464 | /* | |
465 | * These macros are used to bracket UFS directory ops, so that we can | |
466 | * identify all the pages touched during directory ops which need to | |
467 | * be ordered and flushed atomically, so that they may be recovered. | |
468 | */ | |
469 | #define SET_DIROP(fs) { \ | |
3ce71481 | 470 | if ((fs)->lfs_writer) \ |
774279ac | 471 | tsleep(&(fs)->lfs_dirops, PRIBIO + 1, "lfs_dirop", 0); \ |
3ce71481 KB |
472 | ++(fs)->lfs_dirops; \ |
473 | (fs)->lfs_doifile = 1; \ | |
3ce71481 KB |
474 | } |
475 | ||
476 | #define SET_ENDOP(fs) { \ | |
3ce71481 KB |
477 | --(fs)->lfs_dirops; \ |
478 | if (!(fs)->lfs_dirops) \ | |
479 | wakeup(&(fs)->lfs_writer); \ | |
3ce71481 KB |
480 | } |
481 | ||
482 | #define MARK_VNODE(dvp) (dvp)->v_flag |= VDIROP | |
483 | ||
484 | int | |
485 | lfs_symlink(ap) | |
8d50beca KB |
486 | struct vop_symlink_args /* { |
487 | struct vnode *a_dvp; | |
488 | struct vnode **a_vpp; | |
489 | struct componentname *a_cnp; | |
490 | struct vattr *a_vap; | |
491 | char *a_target; | |
492 | } */ *ap; | |
3ce71481 KB |
493 | { |
494 | int ret; | |
495 | ||
496 | SET_DIROP(VTOI(ap->a_dvp)->i_lfs); | |
497 | MARK_VNODE(ap->a_dvp); | |
498 | ret = ufs_symlink(ap); | |
499 | SET_ENDOP(VTOI(ap->a_dvp)->i_lfs); | |
500 | return (ret); | |
501 | } | |
502 | ||
503 | int | |
504 | lfs_mknod(ap) | |
8d50beca KB |
505 | struct vop_mknod_args /* { |
506 | struct vnode *a_dvp; | |
507 | struct vnode **a_vpp; | |
508 | struct componentname *a_cnp; | |
509 | struct vattr *a_vap; | |
510 | } */ *ap; | |
3ce71481 KB |
511 | { |
512 | int ret; | |
513 | ||
514 | SET_DIROP(VTOI(ap->a_dvp)->i_lfs); | |
515 | MARK_VNODE(ap->a_dvp); | |
516 | ret = ufs_mknod(ap); | |
517 | SET_ENDOP(VTOI(ap->a_dvp)->i_lfs); | |
518 | return (ret); | |
519 | } | |
520 | ||
521 | int | |
522 | lfs_create(ap) | |
8d50beca KB |
523 | struct vop_create_args /* { |
524 | struct vnode *a_dvp; | |
525 | struct vnode **a_vpp; | |
526 | struct componentname *a_cnp; | |
527 | struct vattr *a_vap; | |
528 | } */ *ap; | |
3ce71481 KB |
529 | { |
530 | int ret; | |
531 | ||
532 | SET_DIROP(VTOI(ap->a_dvp)->i_lfs); | |
533 | MARK_VNODE(ap->a_dvp); | |
534 | ret = ufs_create(ap); | |
535 | SET_ENDOP(VTOI(ap->a_dvp)->i_lfs); | |
536 | return (ret); | |
537 | } | |
538 | ||
539 | int | |
540 | lfs_mkdir(ap) | |
8d50beca KB |
541 | struct vop_mkdir_args /* { |
542 | struct vnode *a_dvp; | |
543 | struct vnode **a_vpp; | |
544 | struct componentname *a_cnp; | |
545 | struct vattr *a_vap; | |
546 | } */ *ap; | |
3ce71481 KB |
547 | { |
548 | int ret; | |
549 | ||
550 | SET_DIROP(VTOI(ap->a_dvp)->i_lfs); | |
551 | MARK_VNODE(ap->a_dvp); | |
552 | ret = ufs_mkdir(ap); | |
553 | SET_ENDOP(VTOI(ap->a_dvp)->i_lfs); | |
554 | return (ret); | |
555 | } | |
556 | ||
557 | int | |
558 | lfs_remove(ap) | |
8d50beca KB |
559 | struct vop_remove_args /* { |
560 | struct vnode *a_dvp; | |
561 | struct vnode *a_vp; | |
562 | struct componentname *a_cnp; | |
563 | } */ *ap; | |
3ce71481 KB |
564 | { |
565 | int ret; | |
566 | ||
567 | SET_DIROP(VTOI(ap->a_dvp)->i_lfs); | |
568 | MARK_VNODE(ap->a_dvp); | |
569 | MARK_VNODE(ap->a_vp); | |
570 | ret = ufs_remove(ap); | |
571 | SET_ENDOP(VTOI(ap->a_dvp)->i_lfs); | |
572 | return (ret); | |
573 | } | |
574 | ||
575 | int | |
576 | lfs_rmdir(ap) | |
8d50beca KB |
577 | struct vop_rmdir_args /* { |
578 | struct vnodeop_desc *a_desc; | |
579 | struct vnode *a_dvp; | |
580 | struct vnode *a_vp; | |
581 | struct componentname *a_cnp; | |
582 | } */ *ap; | |
3ce71481 KB |
583 | { |
584 | int ret; | |
585 | ||
586 | SET_DIROP(VTOI(ap->a_dvp)->i_lfs); | |
587 | MARK_VNODE(ap->a_dvp); | |
588 | MARK_VNODE(ap->a_vp); | |
589 | ret = ufs_rmdir(ap); | |
590 | SET_ENDOP(VTOI(ap->a_dvp)->i_lfs); | |
591 | return (ret); | |
592 | } | |
593 | ||
594 | int | |
595 | lfs_link(ap) | |
8d50beca KB |
596 | struct vop_link_args /* { |
597 | struct vnode *a_vp; | |
598 | struct vnode *a_tdvp; | |
599 | struct componentname *a_cnp; | |
600 | } */ *ap; | |
3ce71481 KB |
601 | { |
602 | int ret; | |
603 | ||
604 | SET_DIROP(VTOI(ap->a_vp)->i_lfs); | |
605 | MARK_VNODE(ap->a_vp); | |
606 | ret = ufs_link(ap); | |
607 | SET_ENDOP(VTOI(ap->a_vp)->i_lfs); | |
608 | return (ret); | |
609 | } | |
610 | ||
611 | int | |
612 | lfs_rename(ap) | |
8d50beca KB |
613 | struct vop_rename_args /* { |
614 | struct vnode *a_fdvp; | |
615 | struct vnode *a_fvp; | |
616 | struct componentname *a_fcnp; | |
617 | struct vnode *a_tdvp; | |
618 | struct vnode *a_tvp; | |
619 | struct componentname *a_tcnp; | |
620 | } */ *ap; | |
3ce71481 KB |
621 | { |
622 | int ret; | |
623 | ||
624 | SET_DIROP(VTOI(ap->a_fdvp)->i_lfs); | |
625 | MARK_VNODE(ap->a_fdvp); | |
626 | MARK_VNODE(ap->a_tdvp); | |
627 | ret = ufs_rename(ap); | |
628 | SET_ENDOP(VTOI(ap->a_fdvp)->i_lfs); | |
629 | return (ret); | |
630 | } | |
17135473 KB |
631 | /* XXX hack to avoid calling ITIMES in getattr */ |
632 | int | |
633 | lfs_getattr(ap) | |
634 | struct vop_getattr_args /* { | |
635 | struct vnode *a_vp; | |
636 | struct vattr *a_vap; | |
637 | struct ucred *a_cred; | |
638 | struct proc *a_p; | |
639 | } */ *ap; | |
640 | { | |
641 | register struct vnode *vp = ap->a_vp; | |
642 | register struct inode *ip = VTOI(vp); | |
643 | register struct vattr *vap = ap->a_vap; | |
644 | /* | |
645 | * Copy from inode table | |
646 | */ | |
647 | vap->va_fsid = ip->i_dev; | |
648 | vap->va_fileid = ip->i_number; | |
649 | vap->va_mode = ip->i_mode & ~IFMT; | |
650 | vap->va_nlink = ip->i_nlink; | |
651 | vap->va_uid = ip->i_uid; | |
652 | vap->va_gid = ip->i_gid; | |
653 | vap->va_rdev = (dev_t)ip->i_rdev; | |
654 | vap->va_size = ip->i_din.di_size; | |
655 | vap->va_atime = ip->i_atime; | |
656 | vap->va_mtime = ip->i_mtime; | |
657 | vap->va_ctime = ip->i_ctime; | |
658 | vap->va_flags = ip->i_flags; | |
659 | vap->va_gen = ip->i_gen; | |
660 | /* this doesn't belong here */ | |
661 | if (vp->v_type == VBLK) | |
662 | vap->va_blocksize = BLKDEV_IOSIZE; | |
663 | else if (vp->v_type == VCHR) | |
664 | vap->va_blocksize = MAXBSIZE; | |
665 | else | |
666 | vap->va_blocksize = vp->v_mount->mnt_stat.f_iosize; | |
667 | vap->va_bytes = dbtob(ip->i_blocks); | |
668 | vap->va_type = vp->v_type; | |
669 | vap->va_filerev = ip->i_modrev; | |
670 | return (0); | |
671 | } | |
e5b88c97 KB |
672 | /* |
673 | * Close called | |
674 | * | |
675 | * XXX -- we were using ufs_close, but since it updates the | |
676 | * times on the inode, we might need to bump the uinodes | |
677 | * count. | |
678 | */ | |
679 | /* ARGSUSED */ | |
680 | int | |
681 | lfs_close(ap) | |
682 | struct vop_close_args /* { | |
683 | struct vnode *a_vp; | |
684 | int a_fflag; | |
685 | struct ucred *a_cred; | |
686 | struct proc *a_p; | |
687 | } */ *ap; | |
688 | { | |
689 | register struct vnode *vp = ap->a_vp; | |
690 | register struct inode *ip = VTOI(vp); | |
691 | int mod; | |
692 | ||
693 | if (vp->v_usecount > 1 && !(ip->i_flag & ILOCKED)) { | |
694 | mod = ip->i_flag & IMOD; | |
695 | ITIMES(ip, &time, &time); | |
696 | if (!mod && ip->i_flag & IMOD) | |
697 | ip->i_lfs->lfs_uinodes++; | |
698 | } | |
699 | return (0); | |
700 | } | |
701 |