Commit | Line | Data |
---|---|---|
da7c5cc6 | 1 | /* |
80409bdc KB |
2 | * Copyright (c) 1982, 1986, 1989, 1993 |
3 | * The Regents of the University of California. All rights reserved. | |
da7c5cc6 | 4 | * |
b702c21d | 5 | * %sccs.include.redist.c% |
7188ac27 | 6 | * |
b6fa7269 | 7 | * @(#)ffs_vnops.c 8.2 (Berkeley) %G% |
a6673c09 KB |
8 | */ |
9 | ||
10 | #include <sys/param.h> | |
11 | #include <sys/systm.h> | |
a6673c09 KB |
12 | #include <sys/resourcevar.h> |
13 | #include <sys/kernel.h> | |
14 | #include <sys/file.h> | |
15 | #include <sys/stat.h> | |
16 | #include <sys/buf.h> | |
17 | #include <sys/proc.h> | |
18 | #include <sys/conf.h> | |
19 | #include <sys/mount.h> | |
20 | #include <sys/vnode.h> | |
a6673c09 KB |
21 | #include <sys/malloc.h> |
22 | ||
80e9de4e KM |
23 | #include <vm/vm.h> |
24 | ||
41d6cb49 KM |
25 | #include <miscfs/specfs/specdev.h> |
26 | #include <miscfs/fifofs/fifo.h> | |
27 | ||
a6673c09 KB |
28 | #include <ufs/ufs/lockf.h> |
29 | #include <ufs/ufs/quota.h> | |
30 | #include <ufs/ufs/inode.h> | |
31 | #include <ufs/ufs/dir.h> | |
32 | #include <ufs/ufs/ufs_extern.h> | |
33 | ||
34 | #include <ufs/ffs/fs.h> | |
35 | #include <ufs/ffs/ffs_extern.h> | |
36 | ||
37 | /* Global vfs data structures for ufs. */ | |
9342689a JH |
38 | int (**ffs_vnodeop_p)(); |
39 | struct vnodeopv_entry_desc ffs_vnodeop_entries[] = { | |
40 | { &vop_default_desc, vn_default_error }, | |
41 | { &vop_lookup_desc, ufs_lookup }, /* lookup */ | |
42 | { &vop_create_desc, ufs_create }, /* create */ | |
aef53d88 JH |
43 | { &vop_mknod_desc, ufs_mknod }, /* mknod */ |
44 | { &vop_open_desc, ufs_open }, /* open */ | |
45 | { &vop_close_desc, ufs_close }, /* close */ | |
9342689a JH |
46 | { &vop_access_desc, ufs_access }, /* access */ |
47 | { &vop_getattr_desc, ufs_getattr }, /* getattr */ | |
48 | { &vop_setattr_desc, ufs_setattr }, /* setattr */ | |
aef53d88 JH |
49 | { &vop_read_desc, ffs_read }, /* read */ |
50 | { &vop_write_desc, ffs_write }, /* write */ | |
51 | { &vop_ioctl_desc, ufs_ioctl }, /* ioctl */ | |
9342689a | 52 | { &vop_select_desc, ufs_select }, /* select */ |
aef53d88 JH |
53 | { &vop_mmap_desc, ufs_mmap }, /* mmap */ |
54 | { &vop_fsync_desc, ffs_fsync }, /* fsync */ | |
55 | { &vop_seek_desc, ufs_seek }, /* seek */ | |
9342689a | 56 | { &vop_remove_desc, ufs_remove }, /* remove */ |
aef53d88 | 57 | { &vop_link_desc, ufs_link }, /* link */ |
9342689a | 58 | { &vop_rename_desc, ufs_rename }, /* rename */ |
aef53d88 JH |
59 | { &vop_mkdir_desc, ufs_mkdir }, /* mkdir */ |
60 | { &vop_rmdir_desc, ufs_rmdir }, /* rmdir */ | |
9342689a JH |
61 | { &vop_symlink_desc, ufs_symlink }, /* symlink */ |
62 | { &vop_readdir_desc, ufs_readdir }, /* readdir */ | |
63 | { &vop_readlink_desc, ufs_readlink }, /* readlink */ | |
64 | { &vop_abortop_desc, ufs_abortop }, /* abortop */ | |
8ab48e83 | 65 | { &vop_inactive_desc, ufs_inactive }, /* inactive */ |
9342689a | 66 | { &vop_reclaim_desc, ufs_reclaim }, /* reclaim */ |
aef53d88 | 67 | { &vop_lock_desc, ufs_lock }, /* lock */ |
9342689a | 68 | { &vop_unlock_desc, ufs_unlock }, /* unlock */ |
0ae79846 | 69 | { &vop_bmap_desc, ufs_bmap }, /* bmap */ |
9342689a | 70 | { &vop_strategy_desc, ufs_strategy }, /* strategy */ |
aef53d88 | 71 | { &vop_print_desc, ufs_print }, /* print */ |
9342689a | 72 | { &vop_islocked_desc, ufs_islocked }, /* islocked */ |
1642f54b | 73 | { &vop_pathconf_desc, ufs_pathconf }, /* pathconf */ |
9342689a JH |
74 | { &vop_advlock_desc, ufs_advlock }, /* advlock */ |
75 | { &vop_blkatoff_desc, ffs_blkatoff }, /* blkatoff */ | |
9342689a | 76 | { &vop_valloc_desc, ffs_valloc }, /* valloc */ |
aef53d88 | 77 | { &vop_vfree_desc, ffs_vfree }, /* vfree */ |
9342689a JH |
78 | { &vop_truncate_desc, ffs_truncate }, /* truncate */ |
79 | { &vop_update_desc, ffs_update }, /* update */ | |
36c34e72 | 80 | { &vop_bwrite_desc, vn_bwrite }, |
9342689a | 81 | { (struct vnodeop_desc*)NULL, (int(*)())NULL } |
a6673c09 | 82 | }; |
9342689a JH |
83 | struct vnodeopv_desc ffs_vnodeop_opv_desc = |
84 | { &ffs_vnodeop_p, ffs_vnodeop_entries }; | |
528f664c | 85 | |
9342689a JH |
86 | int (**ffs_specop_p)(); |
87 | struct vnodeopv_entry_desc ffs_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 */ | |
aef53d88 | 92 | { &vop_open_desc, spec_open }, /* open */ |
9342689a JH |
93 | { &vop_close_desc, ufsspec_close }, /* close */ |
94 | { &vop_access_desc, ufs_access }, /* access */ | |
95 | { &vop_getattr_desc, ufs_getattr }, /* getattr */ | |
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 */ | |
aef53d88 | 101 | { &vop_mmap_desc, spec_mmap }, /* mmap */ |
06337661 | 102 | { &vop_fsync_desc, ffs_fsync }, /* fsync */ |
aef53d88 | 103 | { &vop_seek_desc, spec_seek }, /* seek */ |
9342689a | 104 | { &vop_remove_desc, spec_remove }, /* remove */ |
aef53d88 | 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 */ | |
8ab48e83 | 113 | { &vop_inactive_desc, ufs_inactive }, /* inactive */ |
9342689a | 114 | { &vop_reclaim_desc, ufs_reclaim }, /* reclaim */ |
aef53d88 | 115 | { &vop_lock_desc, ufs_lock }, /* lock */ |
9342689a | 116 | { &vop_unlock_desc, ufs_unlock }, /* unlock */ |
aef53d88 | 117 | { &vop_bmap_desc, spec_bmap }, /* bmap */ |
9342689a | 118 | { &vop_strategy_desc, spec_strategy }, /* strategy */ |
aef53d88 | 119 | { &vop_print_desc, ufs_print }, /* print */ |
9342689a | 120 | { &vop_islocked_desc, ufs_islocked }, /* islocked */ |
1642f54b | 121 | { &vop_pathconf_desc, spec_pathconf }, /* pathconf */ |
9342689a JH |
122 | { &vop_advlock_desc, spec_advlock }, /* advlock */ |
123 | { &vop_blkatoff_desc, spec_blkatoff }, /* blkatoff */ | |
9342689a | 124 | { &vop_valloc_desc, spec_valloc }, /* valloc */ |
bccabe5d | 125 | { &vop_vfree_desc, ffs_vfree }, /* vfree */ |
9342689a JH |
126 | { &vop_truncate_desc, spec_truncate }, /* truncate */ |
127 | { &vop_update_desc, ffs_update }, /* update */ | |
36c34e72 | 128 | { &vop_bwrite_desc, vn_bwrite }, |
9342689a | 129 | { (struct vnodeop_desc*)NULL, (int(*)())NULL } |
9d5097aa | 130 | }; |
9342689a JH |
131 | struct vnodeopv_desc ffs_specop_opv_desc = |
132 | { &ffs_specop_p, ffs_specop_entries }; | |
9d5097aa KM |
133 | |
134 | #ifdef FIFO | |
9342689a JH |
135 | int (**ffs_fifoop_p)(); |
136 | struct vnodeopv_entry_desc ffs_fifoop_entries[] = { | |
137 | { &vop_default_desc, vn_default_error }, | |
138 | { &vop_lookup_desc, fifo_lookup }, /* lookup */ | |
139 | { &vop_create_desc, fifo_create }, /* create */ | |
140 | { &vop_mknod_desc, fifo_mknod }, /* mknod */ | |
aef53d88 | 141 | { &vop_open_desc, fifo_open }, /* open */ |
9342689a JH |
142 | { &vop_close_desc, ufsfifo_close }, /* close */ |
143 | { &vop_access_desc, ufs_access }, /* access */ | |
144 | { &vop_getattr_desc, ufs_getattr }, /* getattr */ | |
145 | { &vop_setattr_desc, ufs_setattr }, /* setattr */ | |
146 | { &vop_read_desc, ufsfifo_read }, /* read */ | |
147 | { &vop_write_desc, ufsfifo_write }, /* write */ | |
148 | { &vop_ioctl_desc, fifo_ioctl }, /* ioctl */ | |
149 | { &vop_select_desc, fifo_select }, /* select */ | |
aef53d88 | 150 | { &vop_mmap_desc, fifo_mmap }, /* mmap */ |
06337661 | 151 | { &vop_fsync_desc, ffs_fsync }, /* fsync */ |
aef53d88 | 152 | { &vop_seek_desc, fifo_seek }, /* seek */ |
9342689a | 153 | { &vop_remove_desc, fifo_remove }, /* remove */ |
aef53d88 | 154 | { &vop_link_desc, fifo_link }, /* link */ |
9342689a JH |
155 | { &vop_rename_desc, fifo_rename }, /* rename */ |
156 | { &vop_mkdir_desc, fifo_mkdir }, /* mkdir */ | |
157 | { &vop_rmdir_desc, fifo_rmdir }, /* rmdir */ | |
158 | { &vop_symlink_desc, fifo_symlink }, /* symlink */ | |
159 | { &vop_readdir_desc, fifo_readdir }, /* readdir */ | |
160 | { &vop_readlink_desc, fifo_readlink }, /* readlink */ | |
161 | { &vop_abortop_desc, fifo_abortop }, /* abortop */ | |
8ab48e83 | 162 | { &vop_inactive_desc, ufs_inactive }, /* inactive */ |
9342689a | 163 | { &vop_reclaim_desc, ufs_reclaim }, /* reclaim */ |
aef53d88 | 164 | { &vop_lock_desc, ufs_lock }, /* lock */ |
9342689a | 165 | { &vop_unlock_desc, ufs_unlock }, /* unlock */ |
aef53d88 | 166 | { &vop_bmap_desc, fifo_bmap }, /* bmap */ |
9342689a | 167 | { &vop_strategy_desc, fifo_strategy }, /* strategy */ |
aef53d88 | 168 | { &vop_print_desc, ufs_print }, /* print */ |
9342689a | 169 | { &vop_islocked_desc, ufs_islocked }, /* islocked */ |
1642f54b | 170 | { &vop_pathconf_desc, fifo_pathconf }, /* pathconf */ |
9342689a JH |
171 | { &vop_advlock_desc, fifo_advlock }, /* advlock */ |
172 | { &vop_blkatoff_desc, fifo_blkatoff }, /* blkatoff */ | |
9342689a | 173 | { &vop_valloc_desc, fifo_valloc }, /* valloc */ |
bccabe5d | 174 | { &vop_vfree_desc, ffs_vfree }, /* vfree */ |
9342689a JH |
175 | { &vop_truncate_desc, fifo_truncate }, /* truncate */ |
176 | { &vop_update_desc, ffs_update }, /* update */ | |
36c34e72 | 177 | { &vop_bwrite_desc, vn_bwrite }, |
9342689a | 178 | { (struct vnodeop_desc*)NULL, (int(*)())NULL } |
9d5097aa | 179 | }; |
9342689a JH |
180 | struct vnodeopv_desc ffs_fifoop_opv_desc = |
181 | { &ffs_fifoop_p, ffs_fifoop_entries }; | |
9d5097aa KM |
182 | #endif /* FIFO */ |
183 | ||
02abfdb0 KM |
184 | /* |
185 | * Enabling cluster read/write operations. | |
02abfdb0 | 186 | */ |
71d600b8 KM |
187 | #include <sys/sysctl.h> |
188 | int doclusterread = 1; | |
189 | struct ctldebug debug11 = { "doclusterread", &doclusterread }; | |
190 | int doclusterwrite = 1; | |
191 | struct ctldebug debug12 = { "doclusterwrite", &doclusterwrite }; | |
d67a03eb | 192 | |
b6fa7269 | 193 | #include <ufs/ufs/ufs_readwrite.c> |
b373e060 | 194 | |
4f083fd7 | 195 | /* |
7188ac27 | 196 | * Synch an open file. |
4f083fd7 | 197 | */ |
7188ac27 | 198 | /* ARGSUSED */ |
a6673c09 | 199 | int |
cc1475d2 | 200 | ffs_fsync(ap) |
06337661 KM |
201 | struct vop_fsync_args /* { |
202 | struct vnode *a_vp; | |
203 | struct ucred *a_cred; | |
204 | int a_waitfor; | |
205 | struct proc *a_p; | |
206 | } */ *ap; | |
528f664c | 207 | { |
06337661 KM |
208 | register struct vnode *vp = ap->a_vp; |
209 | struct inode *ip = VTOI(vp); | |
210 | register struct buf *bp; | |
d056f176 | 211 | struct timeval tv; |
06337661 KM |
212 | struct buf *nbp; |
213 | int s; | |
7188ac27 | 214 | |
06337661 KM |
215 | /* |
216 | * Flush all dirty buffers associated with a vnode. | |
217 | */ | |
218 | loop: | |
219 | s = splbio(); | |
bd60d0f0 KM |
220 | for (bp = vp->v_dirtyblkhd.le_next; bp; bp = nbp) { |
221 | nbp = bp->b_vnbufs.qe_next; | |
06337661 KM |
222 | if ((bp->b_flags & B_BUSY)) |
223 | continue; | |
224 | if ((bp->b_flags & B_DELWRI) == 0) | |
225 | panic("ffs_fsync: not dirty"); | |
226 | bremfree(bp); | |
227 | bp->b_flags |= B_BUSY; | |
228 | splx(s); | |
229 | /* | |
230 | * Wait for I/O associated with indirect blocks to complete, | |
231 | * since there is no way to quickly wait for them below. | |
232 | */ | |
233 | if (bp->b_vp == vp || ap->a_waitfor == MNT_NOWAIT) | |
234 | (void) bawrite(bp); | |
235 | else | |
236 | (void) bwrite(bp); | |
237 | goto loop; | |
238 | } | |
239 | if (ap->a_waitfor == MNT_WAIT) { | |
240 | while (vp->v_numoutput) { | |
241 | vp->v_flag |= VBWAIT; | |
242 | sleep((caddr_t)&vp->v_numoutput, PRIBIO + 1); | |
243 | } | |
244 | #ifdef DIAGNOSTIC | |
bd60d0f0 | 245 | if (vp->v_dirtyblkhd.le_next) { |
06337661 KM |
246 | vprint("ffs_fsync: dirty", vp); |
247 | goto loop; | |
248 | } | |
249 | #endif | |
250 | } | |
251 | splx(s); | |
d056f176 | 252 | tv = time; |