lfs_vnops.c revision 1.103 1 1.103 perseant /* $NetBSD: lfs_vnops.c,v 1.103 2003/04/23 07:20:39 perseant Exp $ */
2 1.2 cgd
3 1.22 perseant /*-
4 1.84 perseant * Copyright (c) 1999, 2000, 2001, 2002, 2003 The NetBSD Foundation, Inc.
5 1.22 perseant * All rights reserved.
6 1.22 perseant *
7 1.22 perseant * This code is derived from software contributed to The NetBSD Foundation
8 1.22 perseant * by Konrad E. Schroder <perseant (at) hhhh.org>.
9 1.22 perseant *
10 1.22 perseant * Redistribution and use in source and binary forms, with or without
11 1.22 perseant * modification, are permitted provided that the following conditions
12 1.22 perseant * are met:
13 1.22 perseant * 1. Redistributions of source code must retain the above copyright
14 1.22 perseant * notice, this list of conditions and the following disclaimer.
15 1.22 perseant * 2. Redistributions in binary form must reproduce the above copyright
16 1.22 perseant * notice, this list of conditions and the following disclaimer in the
17 1.22 perseant * documentation and/or other materials provided with the distribution.
18 1.22 perseant * 3. All advertising materials mentioning features or use of this software
19 1.22 perseant * must display the following acknowledgement:
20 1.86 perseant * This product includes software developed by the NetBSD
21 1.86 perseant * Foundation, Inc. and its contributors.
22 1.22 perseant * 4. Neither the name of The NetBSD Foundation nor the names of its
23 1.22 perseant * contributors may be used to endorse or promote products derived
24 1.22 perseant * from this software without specific prior written permission.
25 1.22 perseant *
26 1.22 perseant * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
27 1.22 perseant * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
28 1.22 perseant * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
29 1.22 perseant * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
30 1.22 perseant * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
31 1.22 perseant * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
32 1.22 perseant * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
33 1.22 perseant * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
34 1.22 perseant * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
35 1.22 perseant * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
36 1.22 perseant * POSSIBILITY OF SUCH DAMAGE.
37 1.22 perseant */
38 1.1 mycroft /*
39 1.15 fvdl * Copyright (c) 1986, 1989, 1991, 1993, 1995
40 1.1 mycroft * The Regents of the University of California. All rights reserved.
41 1.1 mycroft *
42 1.1 mycroft * Redistribution and use in source and binary forms, with or without
43 1.1 mycroft * modification, are permitted provided that the following conditions
44 1.1 mycroft * are met:
45 1.1 mycroft * 1. Redistributions of source code must retain the above copyright
46 1.1 mycroft * notice, this list of conditions and the following disclaimer.
47 1.1 mycroft * 2. Redistributions in binary form must reproduce the above copyright
48 1.1 mycroft * notice, this list of conditions and the following disclaimer in the
49 1.1 mycroft * documentation and/or other materials provided with the distribution.
50 1.1 mycroft * 3. All advertising materials mentioning features or use of this software
51 1.1 mycroft * must display the following acknowledgement:
52 1.1 mycroft * This product includes software developed by the University of
53 1.1 mycroft * California, Berkeley and its contributors.
54 1.1 mycroft * 4. Neither the name of the University nor the names of its contributors
55 1.1 mycroft * may be used to endorse or promote products derived from this software
56 1.1 mycroft * without specific prior written permission.
57 1.1 mycroft *
58 1.1 mycroft * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
59 1.1 mycroft * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
60 1.1 mycroft * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
61 1.1 mycroft * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
62 1.1 mycroft * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
63 1.1 mycroft * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
64 1.1 mycroft * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
65 1.1 mycroft * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
66 1.1 mycroft * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
67 1.1 mycroft * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
68 1.1 mycroft * SUCH DAMAGE.
69 1.1 mycroft *
70 1.15 fvdl * @(#)lfs_vnops.c 8.13 (Berkeley) 6/10/95
71 1.1 mycroft */
72 1.58 lukem
73 1.58 lukem #include <sys/cdefs.h>
74 1.103 perseant __KERNEL_RCSID(0, "$NetBSD: lfs_vnops.c,v 1.103 2003/04/23 07:20:39 perseant Exp $");
75 1.17 sommerfe
76 1.1 mycroft #include <sys/param.h>
77 1.1 mycroft #include <sys/systm.h>
78 1.1 mycroft #include <sys/namei.h>
79 1.1 mycroft #include <sys/resourcevar.h>
80 1.1 mycroft #include <sys/kernel.h>
81 1.1 mycroft #include <sys/file.h>
82 1.1 mycroft #include <sys/stat.h>
83 1.1 mycroft #include <sys/buf.h>
84 1.1 mycroft #include <sys/proc.h>
85 1.1 mycroft #include <sys/mount.h>
86 1.1 mycroft #include <sys/vnode.h>
87 1.1 mycroft #include <sys/malloc.h>
88 1.19 thorpej #include <sys/pool.h>
89 1.10 christos #include <sys/signalvar.h>
90 1.1 mycroft
91 1.12 mycroft #include <miscfs/fifofs/fifo.h>
92 1.12 mycroft #include <miscfs/genfs/genfs.h>
93 1.1 mycroft #include <miscfs/specfs/specdev.h>
94 1.1 mycroft
95 1.1 mycroft #include <ufs/ufs/inode.h>
96 1.1 mycroft #include <ufs/ufs/dir.h>
97 1.1 mycroft #include <ufs/ufs/ufsmount.h>
98 1.1 mycroft #include <ufs/ufs/ufs_extern.h>
99 1.1 mycroft
100 1.84 perseant #include <uvm/uvm.h>
101 1.95 perseant #include <uvm/uvm_pmap.h>
102 1.95 perseant #include <uvm/uvm_stat.h>
103 1.95 perseant #include <uvm/uvm_pager.h>
104 1.84 perseant
105 1.1 mycroft #include <ufs/lfs/lfs.h>
106 1.1 mycroft #include <ufs/lfs/lfs_extern.h>
107 1.1 mycroft
108 1.91 yamt extern pid_t lfs_writer_daemon;
109 1.84 perseant extern int lfs_subsys_pages;
110 1.96 perseant extern int lfs_dirvcount;
111 1.96 perseant extern struct simplelock lfs_subsys_lock;
112 1.84 perseant
113 1.1 mycroft /* Global vfs data structures for lfs. */
114 1.51 perseant int (**lfs_vnodeop_p)(void *);
115 1.50 jdolecek const struct vnodeopv_entry_desc lfs_vnodeop_entries[] = {
116 1.1 mycroft { &vop_default_desc, vn_default_error },
117 1.1 mycroft { &vop_lookup_desc, ufs_lookup }, /* lookup */
118 1.22 perseant { &vop_create_desc, lfs_create }, /* create */
119 1.82 yamt { &vop_whiteout_desc, ufs_whiteout }, /* whiteout */
120 1.22 perseant { &vop_mknod_desc, lfs_mknod }, /* mknod */
121 1.1 mycroft { &vop_open_desc, ufs_open }, /* open */
122 1.1 mycroft { &vop_close_desc, lfs_close }, /* close */
123 1.1 mycroft { &vop_access_desc, ufs_access }, /* access */
124 1.1 mycroft { &vop_getattr_desc, lfs_getattr }, /* getattr */
125 1.61 perseant { &vop_setattr_desc, lfs_setattr }, /* setattr */
126 1.1 mycroft { &vop_read_desc, lfs_read }, /* read */
127 1.1 mycroft { &vop_write_desc, lfs_write }, /* write */
128 1.4 mycroft { &vop_lease_desc, ufs_lease_check }, /* lease */
129 1.90 perseant { &vop_ioctl_desc, ufs_ioctl }, /* ioctl */
130 1.90 perseant { &vop_fcntl_desc, lfs_fcntl }, /* fcntl */
131 1.13 mycroft { &vop_poll_desc, ufs_poll }, /* poll */
132 1.68 jdolecek { &vop_kqfilter_desc, genfs_kqfilter }, /* kqfilter */
133 1.15 fvdl { &vop_revoke_desc, ufs_revoke }, /* revoke */
134 1.84 perseant { &vop_mmap_desc, lfs_mmap }, /* mmap */
135 1.1 mycroft { &vop_fsync_desc, lfs_fsync }, /* fsync */
136 1.1 mycroft { &vop_seek_desc, ufs_seek }, /* seek */
137 1.22 perseant { &vop_remove_desc, lfs_remove }, /* remove */
138 1.22 perseant { &vop_link_desc, lfs_link }, /* link */
139 1.22 perseant { &vop_rename_desc, lfs_rename }, /* rename */
140 1.22 perseant { &vop_mkdir_desc, lfs_mkdir }, /* mkdir */
141 1.22 perseant { &vop_rmdir_desc, lfs_rmdir }, /* rmdir */
142 1.22 perseant { &vop_symlink_desc, lfs_symlink }, /* symlink */
143 1.1 mycroft { &vop_readdir_desc, ufs_readdir }, /* readdir */
144 1.1 mycroft { &vop_readlink_desc, ufs_readlink }, /* readlink */
145 1.1 mycroft { &vop_abortop_desc, ufs_abortop }, /* abortop */
146 1.40 perseant { &vop_inactive_desc, lfs_inactive }, /* inactive */
147 1.1 mycroft { &vop_reclaim_desc, lfs_reclaim }, /* reclaim */
148 1.1 mycroft { &vop_lock_desc, ufs_lock }, /* lock */
149 1.1 mycroft { &vop_unlock_desc, ufs_unlock }, /* unlock */
150 1.1 mycroft { &vop_bmap_desc, ufs_bmap }, /* bmap */
151 1.94 perseant { &vop_strategy_desc, lfs_strategy }, /* strategy */
152 1.1 mycroft { &vop_print_desc, ufs_print }, /* print */
153 1.1 mycroft { &vop_islocked_desc, ufs_islocked }, /* islocked */
154 1.1 mycroft { &vop_pathconf_desc, ufs_pathconf }, /* pathconf */
155 1.1 mycroft { &vop_advlock_desc, ufs_advlock }, /* advlock */
156 1.1 mycroft { &vop_blkatoff_desc, lfs_blkatoff }, /* blkatoff */
157 1.1 mycroft { &vop_valloc_desc, lfs_valloc }, /* valloc */
158 1.32 fvdl { &vop_balloc_desc, lfs_balloc }, /* balloc */
159 1.1 mycroft { &vop_vfree_desc, lfs_vfree }, /* vfree */
160 1.1 mycroft { &vop_truncate_desc, lfs_truncate }, /* truncate */
161 1.1 mycroft { &vop_update_desc, lfs_update }, /* update */
162 1.1 mycroft { &vop_bwrite_desc, lfs_bwrite }, /* bwrite */
163 1.60 chs { &vop_getpages_desc, lfs_getpages }, /* getpages */
164 1.60 chs { &vop_putpages_desc, lfs_putpages }, /* putpages */
165 1.53 chs { NULL, NULL }
166 1.1 mycroft };
167 1.50 jdolecek const struct vnodeopv_desc lfs_vnodeop_opv_desc =
168 1.1 mycroft { &lfs_vnodeop_p, lfs_vnodeop_entries };
169 1.1 mycroft
170 1.51 perseant int (**lfs_specop_p)(void *);
171 1.50 jdolecek const struct vnodeopv_entry_desc lfs_specop_entries[] = {
172 1.1 mycroft { &vop_default_desc, vn_default_error },
173 1.1 mycroft { &vop_lookup_desc, spec_lookup }, /* lookup */
174 1.1 mycroft { &vop_create_desc, spec_create }, /* create */
175 1.1 mycroft { &vop_mknod_desc, spec_mknod }, /* mknod */
176 1.1 mycroft { &vop_open_desc, spec_open }, /* open */
177 1.65 perseant { &vop_close_desc, lfsspec_close }, /* close */
178 1.1 mycroft { &vop_access_desc, ufs_access }, /* access */
179 1.1 mycroft { &vop_getattr_desc, lfs_getattr }, /* getattr */
180 1.61 perseant { &vop_setattr_desc, lfs_setattr }, /* setattr */
181 1.1 mycroft { &vop_read_desc, ufsspec_read }, /* read */
182 1.1 mycroft { &vop_write_desc, ufsspec_write }, /* write */
183 1.4 mycroft { &vop_lease_desc, spec_lease_check }, /* lease */
184 1.1 mycroft { &vop_ioctl_desc, spec_ioctl }, /* ioctl */
185 1.27 wrstuden { &vop_fcntl_desc, ufs_fcntl }, /* fcntl */
186 1.13 mycroft { &vop_poll_desc, spec_poll }, /* poll */
187 1.68 jdolecek { &vop_kqfilter_desc, spec_kqfilter }, /* kqfilter */
188 1.15 fvdl { &vop_revoke_desc, spec_revoke }, /* revoke */
189 1.1 mycroft { &vop_mmap_desc, spec_mmap }, /* mmap */
190 1.1 mycroft { &vop_fsync_desc, spec_fsync }, /* fsync */
191 1.1 mycroft { &vop_seek_desc, spec_seek }, /* seek */
192 1.1 mycroft { &vop_remove_desc, spec_remove }, /* remove */
193 1.1 mycroft { &vop_link_desc, spec_link }, /* link */
194 1.1 mycroft { &vop_rename_desc, spec_rename }, /* rename */
195 1.1 mycroft { &vop_mkdir_desc, spec_mkdir }, /* mkdir */
196 1.1 mycroft { &vop_rmdir_desc, spec_rmdir }, /* rmdir */
197 1.1 mycroft { &vop_symlink_desc, spec_symlink }, /* symlink */
198 1.1 mycroft { &vop_readdir_desc, spec_readdir }, /* readdir */
199 1.1 mycroft { &vop_readlink_desc, spec_readlink }, /* readlink */
200 1.1 mycroft { &vop_abortop_desc, spec_abortop }, /* abortop */
201 1.40 perseant { &vop_inactive_desc, lfs_inactive }, /* inactive */
202 1.1 mycroft { &vop_reclaim_desc, lfs_reclaim }, /* reclaim */
203 1.1 mycroft { &vop_lock_desc, ufs_lock }, /* lock */
204 1.1 mycroft { &vop_unlock_desc, ufs_unlock }, /* unlock */
205 1.1 mycroft { &vop_bmap_desc, spec_bmap }, /* bmap */
206 1.1 mycroft { &vop_strategy_desc, spec_strategy }, /* strategy */
207 1.1 mycroft { &vop_print_desc, ufs_print }, /* print */
208 1.1 mycroft { &vop_islocked_desc, ufs_islocked }, /* islocked */
209 1.1 mycroft { &vop_pathconf_desc, spec_pathconf }, /* pathconf */
210 1.1 mycroft { &vop_advlock_desc, spec_advlock }, /* advlock */
211 1.1 mycroft { &vop_blkatoff_desc, spec_blkatoff }, /* blkatoff */
212 1.1 mycroft { &vop_valloc_desc, spec_valloc }, /* valloc */
213 1.1 mycroft { &vop_vfree_desc, lfs_vfree }, /* vfree */
214 1.1 mycroft { &vop_truncate_desc, spec_truncate }, /* truncate */
215 1.1 mycroft { &vop_update_desc, lfs_update }, /* update */
216 1.28 perseant { &vop_bwrite_desc, vn_bwrite }, /* bwrite */
217 1.53 chs { &vop_getpages_desc, spec_getpages }, /* getpages */
218 1.53 chs { &vop_putpages_desc, spec_putpages }, /* putpages */
219 1.53 chs { NULL, NULL }
220 1.1 mycroft };
221 1.50 jdolecek const struct vnodeopv_desc lfs_specop_opv_desc =
222 1.1 mycroft { &lfs_specop_p, lfs_specop_entries };
223 1.1 mycroft
224 1.51 perseant int (**lfs_fifoop_p)(void *);
225 1.50 jdolecek const struct vnodeopv_entry_desc lfs_fifoop_entries[] = {
226 1.1 mycroft { &vop_default_desc, vn_default_error },
227 1.1 mycroft { &vop_lookup_desc, fifo_lookup }, /* lookup */
228 1.1 mycroft { &vop_create_desc, fifo_create }, /* create */
229 1.1 mycroft { &vop_mknod_desc, fifo_mknod }, /* mknod */
230 1.1 mycroft { &vop_open_desc, fifo_open }, /* open */
231 1.65 perseant { &vop_close_desc, lfsfifo_close }, /* close */
232 1.1 mycroft { &vop_access_desc, ufs_access }, /* access */
233 1.1 mycroft { &vop_getattr_desc, lfs_getattr }, /* getattr */
234 1.61 perseant { &vop_setattr_desc, lfs_setattr }, /* setattr */
235 1.1 mycroft { &vop_read_desc, ufsfifo_read }, /* read */
236 1.1 mycroft { &vop_write_desc, ufsfifo_write }, /* write */
237 1.4 mycroft { &vop_lease_desc, fifo_lease_check }, /* lease */
238 1.1 mycroft { &vop_ioctl_desc, fifo_ioctl }, /* ioctl */
239 1.27 wrstuden { &vop_fcntl_desc, ufs_fcntl }, /* fcntl */
240 1.13 mycroft { &vop_poll_desc, fifo_poll }, /* poll */
241 1.68 jdolecek { &vop_kqfilter_desc, fifo_kqfilter }, /* kqfilter */
242 1.15 fvdl { &vop_revoke_desc, fifo_revoke }, /* revoke */
243 1.1 mycroft { &vop_mmap_desc, fifo_mmap }, /* mmap */
244 1.1 mycroft { &vop_fsync_desc, fifo_fsync }, /* fsync */
245 1.1 mycroft { &vop_seek_desc, fifo_seek }, /* seek */
246 1.1 mycroft { &vop_remove_desc, fifo_remove }, /* remove */
247 1.1 mycroft { &vop_link_desc, fifo_link }, /* link */
248 1.1 mycroft { &vop_rename_desc, fifo_rename }, /* rename */
249 1.1 mycroft { &vop_mkdir_desc, fifo_mkdir }, /* mkdir */
250 1.1 mycroft { &vop_rmdir_desc, fifo_rmdir }, /* rmdir */
251 1.1 mycroft { &vop_symlink_desc, fifo_symlink }, /* symlink */
252 1.1 mycroft { &vop_readdir_desc, fifo_readdir }, /* readdir */
253 1.1 mycroft { &vop_readlink_desc, fifo_readlink }, /* readlink */
254 1.1 mycroft { &vop_abortop_desc, fifo_abortop }, /* abortop */
255 1.40 perseant { &vop_inactive_desc, lfs_inactive }, /* inactive */
256 1.1 mycroft { &vop_reclaim_desc, lfs_reclaim }, /* reclaim */
257 1.1 mycroft { &vop_lock_desc, ufs_lock }, /* lock */
258 1.1 mycroft { &vop_unlock_desc, ufs_unlock }, /* unlock */
259 1.1 mycroft { &vop_bmap_desc, fifo_bmap }, /* bmap */
260 1.1 mycroft { &vop_strategy_desc, fifo_strategy }, /* strategy */
261 1.1 mycroft { &vop_print_desc, ufs_print }, /* print */
262 1.1 mycroft { &vop_islocked_desc, ufs_islocked }, /* islocked */
263 1.1 mycroft { &vop_pathconf_desc, fifo_pathconf }, /* pathconf */
264 1.1 mycroft { &vop_advlock_desc, fifo_advlock }, /* advlock */
265 1.1 mycroft { &vop_blkatoff_desc, fifo_blkatoff }, /* blkatoff */
266 1.1 mycroft { &vop_valloc_desc, fifo_valloc }, /* valloc */
267 1.1 mycroft { &vop_vfree_desc, lfs_vfree }, /* vfree */
268 1.1 mycroft { &vop_truncate_desc, fifo_truncate }, /* truncate */
269 1.1 mycroft { &vop_update_desc, lfs_update }, /* update */
270 1.1 mycroft { &vop_bwrite_desc, lfs_bwrite }, /* bwrite */
271 1.86 perseant { &vop_putpages_desc, fifo_putpages }, /* putpages */
272 1.53 chs { NULL, NULL }
273 1.1 mycroft };
274 1.50 jdolecek const struct vnodeopv_desc lfs_fifoop_opv_desc =
275 1.1 mycroft { &lfs_fifoop_p, lfs_fifoop_entries };
276 1.1 mycroft
277 1.43 perseant /*
278 1.43 perseant * A function version of LFS_ITIMES, for the UFS functions which call ITIMES
279 1.43 perseant */
280 1.43 perseant void
281 1.51 perseant lfs_itimes(struct inode *ip, struct timespec *acc, struct timespec *mod, struct timespec *cre)
282 1.43 perseant {
283 1.43 perseant LFS_ITIMES(ip, acc, mod, cre);
284 1.43 perseant }
285 1.43 perseant
286 1.1 mycroft #define LFS_READWRITE
287 1.1 mycroft #include <ufs/ufs/ufs_readwrite.c>
288 1.1 mycroft #undef LFS_READWRITE
289 1.1 mycroft
290 1.1 mycroft /*
291 1.1 mycroft * Synch an open file.
292 1.1 mycroft */
293 1.1 mycroft /* ARGSUSED */
294 1.10 christos int
295 1.51 perseant lfs_fsync(void *v)
296 1.10 christos {
297 1.1 mycroft struct vop_fsync_args /* {
298 1.1 mycroft struct vnode *a_vp;
299 1.1 mycroft struct ucred *a_cred;
300 1.22 perseant int a_flags;
301 1.49 toshii off_t offlo;
302 1.49 toshii off_t offhi;
303 1.1 mycroft struct proc *a_p;
304 1.10 christos } */ *ap = v;
305 1.60 chs struct vnode *vp = ap->a_vp;
306 1.84 perseant int error, wait;
307 1.84 perseant
308 1.86 perseant /*
309 1.84 perseant * Trickle sync checks for need to do a checkpoint after possible
310 1.84 perseant * activity from the pagedaemon.
311 1.86 perseant */
312 1.84 perseant if (ap->a_flags & FSYNC_LAZY) {
313 1.84 perseant wakeup(&lfs_writer_daemon);
314 1.47 perseant return 0;
315 1.84 perseant }
316 1.47 perseant
317 1.84 perseant wait = (ap->a_flags & FSYNC_WAIT);
318 1.103 perseant simple_lock(&vp->v_interlock);
319 1.103 perseant error = VOP_PUTPAGES(vp, trunc_page(ap->a_offlo),
320 1.103 perseant round_page(ap->a_offhi),
321 1.103 perseant PGO_CLEANIT | (wait ? PGO_SYNCIO : 0));
322 1.103 perseant if (error)
323 1.103 perseant return error;
324 1.103 perseant error = VOP_UPDATE(vp, NULL, NULL, wait ? UPDATE_WAIT : 0);
325 1.103 perseant if (wait && !VPISEMPTY(vp))
326 1.103 perseant LFS_SET_UINO(VTOI(vp), IN_MODIFIED);
327 1.84 perseant
328 1.63 perseant return error;
329 1.1 mycroft }
330 1.1 mycroft
331 1.1 mycroft /*
332 1.40 perseant * Take IN_ADIROP off, then call ufs_inactive.
333 1.40 perseant */
334 1.40 perseant int
335 1.51 perseant lfs_inactive(void *v)
336 1.40 perseant {
337 1.40 perseant struct vop_inactive_args /* {
338 1.40 perseant struct vnode *a_vp;
339 1.40 perseant struct proc *a_p;
340 1.40 perseant } */ *ap = v;
341 1.72 yamt
342 1.102 fvdl KASSERT(VTOI(ap->a_vp)->i_nlink == VTOI(ap->a_vp)->i_ffs_effnlink);
343 1.77 yamt
344 1.76 yamt lfs_unmark_vnode(ap->a_vp);
345 1.76 yamt
346 1.97 perseant /*
347 1.97 perseant * The Ifile is only ever inactivated on unmount.
348 1.97 perseant * Streamline this process by not giving it more dirty blocks.
349 1.97 perseant */
350 1.97 perseant if (VTOI(ap->a_vp)->i_number == LFS_IFILE_INUM) {
351 1.97 perseant LFS_CLR_UINO(VTOI(ap->a_vp), IN_ALLMOD);
352 1.99 perseant VOP_UNLOCK(ap->a_vp, 0);
353 1.97 perseant return 0;
354 1.97 perseant }
355 1.97 perseant
356 1.75 yamt return ufs_inactive(v);
357 1.40 perseant }
358 1.40 perseant
359 1.40 perseant /*
360 1.1 mycroft * These macros are used to bracket UFS directory ops, so that we can
361 1.1 mycroft * identify all the pages touched during directory ops which need to
362 1.1 mycroft * be ordered and flushed atomically, so that they may be recovered.
363 1.1 mycroft */
364 1.22 perseant /*
365 1.22 perseant * XXX KS - Because we have to mark nodes VDIROP in order to prevent
366 1.22 perseant * the cache from reclaiming them while a dirop is in progress, we must
367 1.22 perseant * also manage the number of nodes so marked (otherwise we can run out).
368 1.22 perseant * We do this by setting lfs_dirvcount to the number of marked vnodes; it
369 1.22 perseant * is decremented during segment write, when VDIROP is taken off.
370 1.22 perseant */
371 1.71 yamt #define SET_DIROP(vp) SET_DIROP2((vp), NULL)
372 1.71 yamt #define SET_DIROP2(vp, vp2) lfs_set_dirop((vp), (vp2))
373 1.71 yamt static int lfs_set_dirop(struct vnode *, struct vnode *);
374 1.31 perseant extern int lfs_dirvcount;
375 1.84 perseant extern int lfs_do_flush;
376 1.24 perseant
377 1.70 yamt #define NRESERVE(fs) (btofsb(fs, (NIADDR + 3 + (2 * NIADDR + 3)) << fs->lfs_bshift))
378 1.70 yamt
379 1.46 perseant static int
380 1.71 yamt lfs_set_dirop(struct vnode *vp, struct vnode *vp2)
381 1.40 perseant {
382 1.24 perseant struct lfs *fs;
383 1.24 perseant int error;
384 1.24 perseant
385 1.71 yamt KASSERT(VOP_ISLOCKED(vp));
386 1.71 yamt KASSERT(vp2 == NULL || VOP_ISLOCKED(vp2));
387 1.71 yamt
388 1.40 perseant fs = VTOI(vp)->i_lfs;
389 1.44 perseant /*
390 1.44 perseant * We might need one directory block plus supporting indirect blocks,
391 1.44 perseant * plus an inode block and ifile page for the new vnode.
392 1.44 perseant */
393 1.71 yamt if ((error = lfs_reserve(fs, vp, vp2, NRESERVE(fs))) != 0)
394 1.44 perseant return (error);
395 1.70 yamt
396 1.40 perseant if (fs->lfs_dirops == 0)
397 1.40 perseant lfs_check(vp, LFS_UNUSED_LBN, 0);
398 1.84 perseant while (fs->lfs_writer || lfs_dirvcount > LFS_MAX_DIROP) {
399 1.59 chs if (fs->lfs_writer)
400 1.63 perseant tsleep(&fs->lfs_dirops, PRIBIO + 1, "lfs_sdirop", 0);
401 1.84 perseant if (lfs_dirvcount > LFS_MAX_DIROP && fs->lfs_dirops == 0) {
402 1.84 perseant wakeup(&lfs_writer_daemon);
403 1.84 perseant preempt(NULL);
404 1.33 perseant }
405 1.33 perseant
406 1.84 perseant if (lfs_dirvcount > LFS_MAX_DIROP) {
407 1.24 perseant #ifdef DEBUG_LFS
408 1.44 perseant printf("lfs_set_dirop: sleeping with dirops=%d, "
409 1.44 perseant "dirvcount=%d\n", fs->lfs_dirops,
410 1.44 perseant lfs_dirvcount);
411 1.24 perseant #endif
412 1.59 chs if ((error = tsleep(&lfs_dirvcount, PCATCH|PUSER,
413 1.59 chs "lfs_maxdirop", 0)) != 0) {
414 1.70 yamt goto unreserve;
415 1.44 perseant }
416 1.24 perseant }
417 1.24 perseant }
418 1.24 perseant ++fs->lfs_dirops;
419 1.24 perseant fs->lfs_doifile = 1;
420 1.24 perseant
421 1.46 perseant /* Hold a reference so SET_ENDOP will be happy */
422 1.78 yamt vref(vp);
423 1.78 yamt if (vp2)
424 1.78 yamt vref(vp2);
425 1.46 perseant
426 1.24 perseant return 0;
427 1.70 yamt
428 1.70 yamt unreserve:
429 1.71 yamt lfs_reserve(fs, vp, vp2, -NRESERVE(fs));
430 1.70 yamt return error;
431 1.1 mycroft }
432 1.1 mycroft
433 1.71 yamt #define SET_ENDOP(fs, vp, str) SET_ENDOP2((fs), (vp), NULL, (str))
434 1.71 yamt #define SET_ENDOP2(fs, vp, vp2, str) { \
435 1.1 mycroft --(fs)->lfs_dirops; \
436 1.22 perseant if (!(fs)->lfs_dirops) { \
437 1.40 perseant if ((fs)->lfs_nadirop) { \
438 1.67 provos panic("SET_ENDOP: %s: no dirops but nadirop=%d", \
439 1.40 perseant (str), (fs)->lfs_nadirop); \
440 1.40 perseant } \
441 1.1 mycroft wakeup(&(fs)->lfs_writer); \
442 1.26 perseant lfs_check((vp),LFS_UNUSED_LBN,0); \
443 1.22 perseant } \
444 1.71 yamt lfs_reserve((fs), vp, vp2, -NRESERVE(fs)); /* XXX */ \
445 1.78 yamt vrele(vp); \
446 1.78 yamt if (vp2) \
447 1.78 yamt vrele(vp2); \
448 1.1 mycroft }
449 1.1 mycroft
450 1.86 perseant #define MARK_VNODE(dvp) do { \
451 1.84 perseant struct inode *_ip = VTOI(dvp); \
452 1.84 perseant struct lfs *_fs = _ip->i_lfs; \
453 1.84 perseant \
454 1.86 perseant if (!((dvp)->v_flag & VDIROP)) { \
455 1.86 perseant (void)lfs_vref(dvp); \
456 1.31 perseant ++lfs_dirvcount; \
457 1.84 perseant TAILQ_INSERT_TAIL(&_fs->lfs_dchainhd, _ip, i_lfs_dchain); \
458 1.22 perseant } \
459 1.86 perseant (dvp)->v_flag |= VDIROP; \
460 1.84 perseant if (!(_ip->i_flag & IN_ADIROP)) { \
461 1.84 perseant ++_fs->lfs_nadirop; \
462 1.37 perseant } \
463 1.84 perseant _ip->i_flag |= IN_ADIROP; \
464 1.59 chs } while (0)
465 1.37 perseant
466 1.40 perseant #define UNMARK_VNODE(vp) lfs_unmark_vnode(vp)
467 1.40 perseant
468 1.51 perseant void lfs_unmark_vnode(struct vnode *vp)
469 1.40 perseant {
470 1.40 perseant struct inode *ip;
471 1.40 perseant
472 1.40 perseant ip = VTOI(vp);
473 1.40 perseant
474 1.40 perseant if (ip->i_flag & IN_ADIROP)
475 1.40 perseant --ip->i_lfs->lfs_nadirop;
476 1.40 perseant ip->i_flag &= ~IN_ADIROP;
477 1.40 perseant }
478 1.15 fvdl
479 1.1 mycroft int
480 1.51 perseant lfs_symlink(void *v)
481 1.10 christos {
482 1.1 mycroft struct vop_symlink_args /* {
483 1.1 mycroft struct vnode *a_dvp;
484 1.1 mycroft struct vnode **a_vpp;
485 1.1 mycroft struct componentname *a_cnp;
486 1.1 mycroft struct vattr *a_vap;
487 1.1 mycroft char *a_target;
488 1.10 christos } */ *ap = v;
489 1.37 perseant int error;
490 1.1 mycroft
491 1.40 perseant if ((error = SET_DIROP(ap->a_dvp)) != 0) {
492 1.34 perseant vput(ap->a_dvp);
493 1.37 perseant return error;
494 1.34 perseant }
495 1.1 mycroft MARK_VNODE(ap->a_dvp);
496 1.37 perseant error = ufs_symlink(ap);
497 1.37 perseant UNMARK_VNODE(ap->a_dvp);
498 1.40 perseant if (*(ap->a_vpp))
499 1.37 perseant UNMARK_VNODE(*(ap->a_vpp));
500 1.37 perseant SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"symlink");
501 1.37 perseant return (error);
502 1.1 mycroft }
503 1.1 mycroft
504 1.1 mycroft int
505 1.51 perseant lfs_mknod(void *v)
506 1.10 christos {
507 1.22 perseant struct vop_mknod_args /* {
508 1.1 mycroft struct vnode *a_dvp;
509 1.1 mycroft struct vnode **a_vpp;
510 1.1 mycroft struct componentname *a_cnp;
511 1.1 mycroft struct vattr *a_vap;
512 1.22 perseant } */ *ap = v;
513 1.86 perseant struct vattr *vap = ap->a_vap;
514 1.86 perseant struct vnode **vpp = ap->a_vpp;
515 1.86 perseant struct inode *ip;
516 1.86 perseant int error;
517 1.52 assar struct mount *mp;
518 1.52 assar ino_t ino;
519 1.1 mycroft
520 1.40 perseant if ((error = SET_DIROP(ap->a_dvp)) != 0) {
521 1.34 perseant vput(ap->a_dvp);
522 1.28 perseant return error;
523 1.34 perseant }
524 1.1 mycroft MARK_VNODE(ap->a_dvp);
525 1.28 perseant error = ufs_makeinode(MAKEIMODE(vap->va_type, vap->va_mode),
526 1.86 perseant ap->a_dvp, vpp, ap->a_cnp);
527 1.37 perseant UNMARK_VNODE(ap->a_dvp);
528 1.86 perseant if (*(ap->a_vpp))
529 1.86 perseant UNMARK_VNODE(*(ap->a_vpp));
530 1.28 perseant
531 1.28 perseant /* Either way we're done with the dirop at this point */
532 1.26 perseant SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"mknod");
533 1.28 perseant
534 1.86 perseant if (error)
535 1.28 perseant return (error);
536 1.28 perseant
537 1.86 perseant ip = VTOI(*vpp);
538 1.52 assar mp = (*vpp)->v_mount;
539 1.52 assar ino = ip->i_number;
540 1.86 perseant ip->i_flag |= IN_ACCESS | IN_CHANGE | IN_UPDATE;
541 1.86 perseant if (vap->va_rdev != VNOVAL) {
542 1.86 perseant /*
543 1.86 perseant * Want to be able to use this to make badblock
544 1.86 perseant * inodes, so don't truncate the dev number.
545 1.86 perseant */
546 1.28 perseant #if 0
547 1.102 fvdl ip->i_ffs1_rdev = ufs_rw32(vap->va_rdev,
548 1.86 perseant UFS_MPNEEDSWAP((*vpp)->v_mount));
549 1.28 perseant #else
550 1.102 fvdl ip->i_ffs1_rdev = vap->va_rdev;
551 1.28 perseant #endif
552 1.86 perseant }
553 1.28 perseant /*
554 1.28 perseant * Call fsync to write the vnode so that we don't have to deal with
555 1.28 perseant * flushing it when it's marked VDIROP|VXLOCK.
556 1.28 perseant *
557 1.28 perseant * XXX KS - If we can't flush we also can't call vgone(), so must
558 1.28 perseant * return. But, that leaves this vnode in limbo, also not good.
559 1.28 perseant * Can this ever happen (barring hardware failure)?
560 1.28 perseant */
561 1.80 thorpej if ((error = VOP_FSYNC(*vpp, NOCRED, FSYNC_WAIT, 0, 0,
562 1.80 thorpej curproc)) != 0) {
563 1.40 perseant printf("Couldn't fsync in mknod (ino %d)---what do I do?\n",
564 1.40 perseant VTOI(*vpp)->i_number);
565 1.28 perseant return (error);
566 1.40 perseant }
567 1.86 perseant /*
568 1.86 perseant * Remove vnode so that it will be reloaded by VFS_VGET and
569 1.86 perseant * checked to see if it is an alias of an existing entry in
570 1.86 perseant * the inode cache.
571 1.86 perseant */
572 1.28 perseant /* Used to be vput, but that causes us to call VOP_INACTIVE twice. */
573 1.40 perseant VOP_UNLOCK(*vpp, 0);
574 1.28 perseant lfs_vunref(*vpp);
575 1.86 perseant (*vpp)->v_type = VNON;
576 1.86 perseant vgone(*vpp);
577 1.52 assar error = VFS_VGET(mp, ino, vpp);
578 1.52 assar if (error != 0) {
579 1.52 assar *vpp = NULL;
580 1.52 assar return (error);
581 1.52 assar }
582 1.86 perseant return (0);
583 1.1 mycroft }
584 1.1 mycroft
585 1.1 mycroft int
586 1.51 perseant lfs_create(void *v)
587 1.10 christos {
588 1.22 perseant struct vop_create_args /* {
589 1.1 mycroft struct vnode *a_dvp;
590 1.1 mycroft struct vnode **a_vpp;
591 1.1 mycroft struct componentname *a_cnp;
592 1.1 mycroft struct vattr *a_vap;
593 1.10 christos } */ *ap = v;
594 1.37 perseant int error;
595 1.1 mycroft
596 1.59 chs if ((error = SET_DIROP(ap->a_dvp)) != 0) {
597 1.34 perseant vput(ap->a_dvp);
598 1.37 perseant return error;
599 1.34 perseant }
600 1.1 mycroft MARK_VNODE(ap->a_dvp);
601 1.37 perseant error = ufs_create(ap);
602 1.37 perseant UNMARK_VNODE(ap->a_dvp);
603 1.86 perseant if (*(ap->a_vpp))
604 1.86 perseant UNMARK_VNODE(*(ap->a_vpp));
605 1.26 perseant SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"create");
606 1.37 perseant return (error);
607 1.22 perseant }
608 1.22 perseant
609 1.22 perseant int
610 1.51 perseant lfs_mkdir(void *v)
611 1.10 christos {
612 1.22 perseant struct vop_mkdir_args /* {
613 1.1 mycroft struct vnode *a_dvp;
614 1.1 mycroft struct vnode **a_vpp;
615 1.1 mycroft struct componentname *a_cnp;
616 1.1 mycroft struct vattr *a_vap;
617 1.10 christos } */ *ap = v;
618 1.37 perseant int error;
619 1.1 mycroft
620 1.59 chs if ((error = SET_DIROP(ap->a_dvp)) != 0) {
621 1.34 perseant vput(ap->a_dvp);
622 1.37 perseant return error;
623 1.34 perseant }
624 1.1 mycroft MARK_VNODE(ap->a_dvp);
625 1.37 perseant error = ufs_mkdir(ap);
626 1.37 perseant UNMARK_VNODE(ap->a_dvp);
627 1.86 perseant if (*(ap->a_vpp))
628 1.86 perseant UNMARK_VNODE(*(ap->a_vpp));
629 1.26 perseant SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"mkdir");
630 1.37 perseant return (error);
631 1.1 mycroft }
632 1.1 mycroft
633 1.1 mycroft int
634 1.51 perseant lfs_remove(void *v)
635 1.10 christos {
636 1.22 perseant struct vop_remove_args /* {
637 1.1 mycroft struct vnode *a_dvp;
638 1.1 mycroft struct vnode *a_vp;
639 1.1 mycroft struct componentname *a_cnp;
640 1.10 christos } */ *ap = v;
641 1.34 perseant struct vnode *dvp, *vp;
642 1.37 perseant int error;
643 1.34 perseant
644 1.34 perseant dvp = ap->a_dvp;
645 1.34 perseant vp = ap->a_vp;
646 1.71 yamt if ((error = SET_DIROP2(dvp, vp)) != 0) {
647 1.34 perseant if (dvp == vp)
648 1.34 perseant vrele(vp);
649 1.34 perseant else
650 1.34 perseant vput(vp);
651 1.34 perseant vput(dvp);
652 1.37 perseant return error;
653 1.34 perseant }
654 1.34 perseant MARK_VNODE(dvp);
655 1.34 perseant MARK_VNODE(vp);
656 1.37 perseant error = ufs_remove(ap);
657 1.37 perseant UNMARK_VNODE(dvp);
658 1.37 perseant UNMARK_VNODE(vp);
659 1.40 perseant
660 1.71 yamt SET_ENDOP2(VTOI(dvp)->i_lfs, dvp, vp, "remove");
661 1.37 perseant return (error);
662 1.1 mycroft }
663 1.1 mycroft
664 1.1 mycroft int
665 1.51 perseant lfs_rmdir(void *v)
666 1.10 christos {
667 1.22 perseant struct vop_rmdir_args /* {
668 1.1 mycroft struct vnodeop_desc *a_desc;
669 1.1 mycroft struct vnode *a_dvp;
670 1.1 mycroft struct vnode *a_vp;
671 1.1 mycroft struct componentname *a_cnp;
672 1.10 christos } */ *ap = v;
673 1.84 perseant struct vnode *vp;
674 1.37 perseant int error;
675 1.1 mycroft
676 1.84 perseant vp = ap->a_vp;
677 1.71 yamt if ((error = SET_DIROP2(ap->a_dvp, ap->a_vp)) != 0) {
678 1.34 perseant vrele(ap->a_dvp);
679 1.69 yamt if (ap->a_vp != ap->a_dvp)
680 1.34 perseant VOP_UNLOCK(ap->a_dvp, 0);
681 1.84 perseant vput(vp);
682 1.37 perseant return error;
683 1.34 perseant }
684 1.1 mycroft MARK_VNODE(ap->a_dvp);
685 1.84 perseant MARK_VNODE(vp);
686 1.37 perseant error = ufs_rmdir(ap);
687 1.37 perseant UNMARK_VNODE(ap->a_dvp);
688 1.84 perseant UNMARK_VNODE(vp);
689 1.40 perseant
690 1.84 perseant SET_ENDOP2(VTOI(ap->a_dvp)->i_lfs, ap->a_dvp, vp, "rmdir");
691 1.37 perseant return (error);
692 1.1 mycroft }
693 1.1 mycroft
694 1.1 mycroft int
695 1.51 perseant lfs_link(void *v)
696 1.10 christos {
697 1.22 perseant struct vop_link_args /* {
698 1.9 mycroft struct vnode *a_dvp;
699 1.1 mycroft struct vnode *a_vp;
700 1.1 mycroft struct componentname *a_cnp;
701 1.10 christos } */ *ap = v;
702 1.37 perseant int error;
703 1.1 mycroft
704 1.40 perseant if ((error = SET_DIROP(ap->a_dvp)) != 0) {
705 1.34 perseant vput(ap->a_dvp);
706 1.37 perseant return error;
707 1.34 perseant }
708 1.9 mycroft MARK_VNODE(ap->a_dvp);
709 1.37 perseant error = ufs_link(ap);
710 1.37 perseant UNMARK_VNODE(ap->a_dvp);
711 1.26 perseant SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"link");
712 1.37 perseant return (error);
713 1.1 mycroft }
714 1.22 perseant
715 1.1 mycroft int
716 1.51 perseant lfs_rename(void *v)
717 1.10 christos {
718 1.22 perseant struct vop_rename_args /* {
719 1.1 mycroft struct vnode *a_fdvp;
720 1.1 mycroft struct vnode *a_fvp;
721 1.1 mycroft struct componentname *a_fcnp;
722 1.1 mycroft struct vnode *a_tdvp;
723 1.1 mycroft struct vnode *a_tvp;
724 1.1 mycroft struct componentname *a_tcnp;
725 1.10 christos } */ *ap = v;
726 1.30 perseant struct vnode *tvp, *fvp, *tdvp, *fdvp;
727 1.83 perseant struct componentname *tcnp, *fcnp;
728 1.30 perseant int error;
729 1.29 perseant struct lfs *fs;
730 1.29 perseant
731 1.29 perseant fs = VTOI(ap->a_fdvp)->i_lfs;
732 1.30 perseant tvp = ap->a_tvp;
733 1.30 perseant tdvp = ap->a_tdvp;
734 1.83 perseant tcnp = ap->a_tcnp;
735 1.30 perseant fvp = ap->a_fvp;
736 1.30 perseant fdvp = ap->a_fdvp;
737 1.83 perseant fcnp = ap->a_fcnp;
738 1.30 perseant
739 1.30 perseant /*
740 1.30 perseant * Check for cross-device rename.
741 1.30 perseant * If it is, we don't want to set dirops, just error out.
742 1.30 perseant * (In particular note that MARK_VNODE(tdvp) will DTWT on
743 1.30 perseant * a cross-device rename.)
744 1.30 perseant *
745 1.30 perseant * Copied from ufs_rename.
746 1.30 perseant */
747 1.30 perseant if ((fvp->v_mount != tdvp->v_mount) ||
748 1.30 perseant (tvp && (fvp->v_mount != tvp->v_mount))) {
749 1.30 perseant error = EXDEV;
750 1.34 perseant goto errout;
751 1.30 perseant }
752 1.83 perseant
753 1.83 perseant /*
754 1.83 perseant * Check to make sure we're not renaming a vnode onto itself
755 1.83 perseant * (deleting a hard link by renaming one name onto another);
756 1.83 perseant * if we are we can't recursively call VOP_REMOVE since that
757 1.83 perseant * would leave us with an unaccounted-for number of live dirops.
758 1.83 perseant *
759 1.83 perseant * Inline the relevant section of ufs_rename here, *before*
760 1.83 perseant * calling SET_DIROP2.
761 1.83 perseant */
762 1.102 fvdl if (tvp && ((VTOI(tvp)->i_flags & (IMMUTABLE | APPEND)) ||
763 1.102 fvdl (VTOI(tdvp)->i_flags & APPEND))) {
764 1.83 perseant error = EPERM;
765 1.83 perseant goto errout;
766 1.83 perseant }
767 1.86 perseant if (fvp == tvp) {
768 1.86 perseant if (fvp->v_type == VDIR) {
769 1.86 perseant error = EINVAL;
770 1.86 perseant goto errout;
771 1.86 perseant }
772 1.86 perseant
773 1.86 perseant /* Release destination completely. */
774 1.86 perseant VOP_ABORTOP(tdvp, tcnp);
775 1.86 perseant vput(tdvp);
776 1.86 perseant vput(tvp);
777 1.86 perseant
778 1.86 perseant /* Delete source. */
779 1.86 perseant vrele(fvp);
780 1.86 perseant fcnp->cn_flags &= ~(MODMASK | SAVESTART);
781 1.86 perseant fcnp->cn_flags |= LOCKPARENT | LOCKLEAF;
782 1.86 perseant fcnp->cn_nameiop = DELETE;
783 1.86 perseant if ((error = relookup(fdvp, &fvp, fcnp))){
784 1.86 perseant /* relookup blew away fdvp */
785 1.86 perseant return (error);
786 1.86 perseant }
787 1.86 perseant return (VOP_REMOVE(fdvp, fvp, fcnp));
788 1.86 perseant }
789 1.83 perseant
790 1.71 yamt if ((error = SET_DIROP2(tdvp, tvp)) != 0)
791 1.34 perseant goto errout;
792 1.30 perseant MARK_VNODE(fdvp);
793 1.30 perseant MARK_VNODE(tdvp);
794 1.71 yamt MARK_VNODE(fvp);
795 1.71 yamt if (tvp) {
796 1.71 yamt MARK_VNODE(tvp);
797 1.71 yamt }
798 1.83 perseant
799 1.30 perseant error = ufs_rename(ap);
800 1.37 perseant UNMARK_VNODE(fdvp);
801 1.37 perseant UNMARK_VNODE(tdvp);
802 1.71 yamt UNMARK_VNODE(fvp);
803 1.71 yamt if (tvp) {
804 1.71 yamt UNMARK_VNODE(tvp);
805 1.71 yamt }
806 1.71 yamt SET_ENDOP2(fs, tdvp, tvp, "rename");
807 1.34 perseant return (error);
808 1.34 perseant
809 1.34 perseant errout:
810 1.34 perseant VOP_ABORTOP(tdvp, ap->a_tcnp); /* XXX, why not in NFS? */
811 1.34 perseant if (tdvp == tvp)
812 1.34 perseant vrele(tdvp);
813 1.34 perseant else
814 1.34 perseant vput(tdvp);
815 1.34 perseant if (tvp)
816 1.34 perseant vput(tvp);
817 1.34 perseant VOP_ABORTOP(fdvp, ap->a_fcnp); /* XXX, why not in NFS? */
818 1.34 perseant vrele(fdvp);
819 1.34 perseant vrele(fvp);
820 1.30 perseant return (error);
821 1.1 mycroft }
822 1.22 perseant
823 1.1 mycroft /* XXX hack to avoid calling ITIMES in getattr */
824 1.1 mycroft int
825 1.51 perseant lfs_getattr(void *v)
826 1.10 christos {
827 1.1 mycroft struct vop_getattr_args /* {
828 1.1 mycroft struct vnode *a_vp;
829 1.1 mycroft struct vattr *a_vap;
830 1.1 mycroft struct ucred *a_cred;
831 1.1 mycroft struct proc *a_p;
832 1.10 christos } */ *ap = v;
833 1.35 augustss struct vnode *vp = ap->a_vp;
834 1.35 augustss struct inode *ip = VTOI(vp);
835 1.35 augustss struct vattr *vap = ap->a_vap;
836 1.51 perseant struct lfs *fs = ip->i_lfs;
837 1.1 mycroft /*
838 1.1 mycroft * Copy from inode table
839 1.1 mycroft */
840 1.1 mycroft vap->va_fsid = ip->i_dev;
841 1.1 mycroft vap->va_fileid = ip->i_number;
842 1.102 fvdl vap->va_mode = ip->i_mode & ~IFMT;
843 1.102 fvdl vap->va_nlink = ip->i_nlink;
844 1.102 fvdl vap->va_uid = ip->i_uid;
845 1.102 fvdl vap->va_gid = ip->i_gid;
846 1.102 fvdl vap->va_rdev = (dev_t)ip->i_ffs1_rdev;
847 1.55 chs vap->va_size = vp->v_size;
848 1.102 fvdl vap->va_atime.tv_sec = ip->i_ffs1_atime;
849 1.102 fvdl vap->va_atime.tv_nsec = ip->i_ffs1_atimensec;
850 1.102 fvdl vap->va_mtime.tv_sec = ip->i_ffs1_mtime;
851 1.102 fvdl vap->va_mtime.tv_nsec = ip->i_ffs1_mtimensec;
852 1.102 fvdl vap->va_ctime.tv_sec = ip->i_ffs1_ctime;
853 1.102 fvdl vap->va_ctime.tv_nsec = ip->i_ffs1_ctimensec;
854 1.102 fvdl vap->va_flags = ip->i_flags;
855 1.102 fvdl vap->va_gen = ip->i_gen;
856 1.1 mycroft /* this doesn't belong here */
857 1.1 mycroft if (vp->v_type == VBLK)
858 1.1 mycroft vap->va_blocksize = BLKDEV_IOSIZE;
859 1.1 mycroft else if (vp->v_type == VCHR)
860 1.1 mycroft vap->va_blocksize = MAXBSIZE;
861 1.1 mycroft else
862 1.1 mycroft vap->va_blocksize = vp->v_mount->mnt_stat.f_iosize;
863 1.84 perseant vap->va_bytes = fsbtob(fs, (u_quad_t)ip->i_lfs_effnblks);
864 1.1 mycroft vap->va_type = vp->v_type;
865 1.1 mycroft vap->va_filerev = ip->i_modrev;
866 1.1 mycroft return (0);
867 1.61 perseant }
868 1.61 perseant
869 1.61 perseant /*
870 1.61 perseant * Check to make sure the inode blocks won't choke the buffer
871 1.61 perseant * cache, then call ufs_setattr as usual.
872 1.61 perseant */
873 1.61 perseant int
874 1.61 perseant lfs_setattr(void *v)
875 1.61 perseant {
876 1.61 perseant struct vop_getattr_args /* {
877 1.61 perseant struct vnode *a_vp;
878 1.61 perseant struct vattr *a_vap;
879 1.61 perseant struct ucred *a_cred;
880 1.61 perseant struct proc *a_p;
881 1.61 perseant } */ *ap = v;
882 1.61 perseant struct vnode *vp = ap->a_vp;
883 1.61 perseant
884 1.61 perseant lfs_check(vp, LFS_UNUSED_LBN, 0);
885 1.61 perseant return ufs_setattr(v);
886 1.1 mycroft }
887 1.22 perseant
888 1.1 mycroft /*
889 1.1 mycroft * Close called
890 1.1 mycroft *
891 1.1 mycroft * XXX -- we were using ufs_close, but since it updates the
892 1.1 mycroft * times on the inode, we might need to bump the uinodes
893 1.1 mycroft * count.
894 1.1 mycroft */
895 1.1 mycroft /* ARGSUSED */
896 1.1 mycroft int
897 1.51 perseant lfs_close(void *v)
898 1.10 christos {
899 1.1 mycroft struct vop_close_args /* {
900 1.1 mycroft struct vnode *a_vp;
901 1.1 mycroft int a_fflag;
902 1.1 mycroft struct ucred *a_cred;
903 1.1 mycroft struct proc *a_p;
904 1.10 christos } */ *ap = v;
905 1.35 augustss struct vnode *vp = ap->a_vp;
906 1.35 augustss struct inode *ip = VTOI(vp);
907 1.12 mycroft struct timespec ts;
908 1.1 mycroft
909 1.97 perseant if (vp == ip->i_lfs->lfs_ivnode &&
910 1.97 perseant vp->v_mount->mnt_flag & MNT_UNMOUNT)
911 1.97 perseant return 0;
912 1.97 perseant
913 1.97 perseant if (vp->v_usecount > 1 && vp != ip->i_lfs->lfs_ivnode) {
914 1.12 mycroft TIMEVAL_TO_TIMESPEC(&time, &ts);
915 1.22 perseant LFS_ITIMES(ip, &ts, &ts, &ts);
916 1.1 mycroft }
917 1.1 mycroft return (0);
918 1.65 perseant }
919 1.65 perseant
920 1.65 perseant /*
921 1.65 perseant * Close wrapper for special devices.
922 1.65 perseant *
923 1.65 perseant * Update the times on the inode then do device close.
924 1.65 perseant */
925 1.65 perseant int
926 1.65 perseant lfsspec_close(void *v)
927 1.65 perseant {
928 1.65 perseant struct vop_close_args /* {
929 1.65 perseant struct vnode *a_vp;
930 1.65 perseant int a_fflag;
931 1.65 perseant struct ucred *a_cred;
932 1.65 perseant struct proc *a_p;
933 1.65 perseant } */ *ap = v;
934 1.65 perseant struct vnode *vp;
935 1.65 perseant struct inode *ip;
936 1.65 perseant struct timespec ts;
937 1.65 perseant
938 1.65 perseant vp = ap->a_vp;
939 1.65 perseant ip = VTOI(vp);
940 1.65 perseant if (vp->v_usecount > 1) {
941 1.65 perseant TIMEVAL_TO_TIMESPEC(&time, &ts);
942 1.65 perseant LFS_ITIMES(ip, &ts, &ts, &ts);
943 1.65 perseant }
944 1.65 perseant return (VOCALL (spec_vnodeop_p, VOFFSET(vop_close), ap));
945 1.65 perseant }
946 1.65 perseant
947 1.65 perseant /*
948 1.65 perseant * Close wrapper for fifo's.
949 1.65 perseant *
950 1.65 perseant * Update the times on the inode then do device close.
951 1.65 perseant */
952 1.65 perseant int
953 1.65 perseant lfsfifo_close(void *v)
954 1.65 perseant {
955 1.65 perseant struct vop_close_args /* {
956 1.65 perseant struct vnode *a_vp;
957 1.65 perseant int a_fflag;
958 1.65 perseant struct ucred *a_cred;
959 1.65 perseant struct proc *a_p;
960 1.65 perseant } */ *ap = v;
961 1.65 perseant struct vnode *vp;
962 1.65 perseant struct inode *ip;
963 1.65 perseant struct timespec ts;
964 1.65 perseant
965 1.65 perseant vp = ap->a_vp;
966 1.65 perseant ip = VTOI(vp);
967 1.65 perseant if (ap->a_vp->v_usecount > 1) {
968 1.65 perseant TIMEVAL_TO_TIMESPEC(&time, &ts);
969 1.65 perseant LFS_ITIMES(ip, &ts, &ts, &ts);
970 1.65 perseant }
971 1.65 perseant return (VOCALL (fifo_vnodeop_p, VOFFSET(vop_close), ap));
972 1.1 mycroft }
973 1.1 mycroft
974 1.1 mycroft /*
975 1.15 fvdl * Reclaim an inode so that it can be used for other purposes.
976 1.1 mycroft */
977 1.1 mycroft int lfs_no_inactive = 0;
978 1.1 mycroft
979 1.1 mycroft int
980 1.51 perseant lfs_reclaim(void *v)
981 1.10 christos {
982 1.1 mycroft struct vop_reclaim_args /* {
983 1.1 mycroft struct vnode *a_vp;
984 1.15 fvdl struct proc *a_p;
985 1.10 christos } */ *ap = v;
986 1.15 fvdl struct vnode *vp = ap->a_vp;
987 1.84 perseant struct inode *ip = VTOI(vp);
988 1.1 mycroft int error;
989 1.77 yamt
990 1.102 fvdl KASSERT(ip->i_nlink == ip->i_ffs_effnlink);
991 1.1 mycroft
992 1.84 perseant LFS_CLR_UINO(ip, IN_ALLMOD);
993 1.15 fvdl if ((error = ufs_reclaim(vp, ap->a_p)))
994 1.1 mycroft return (error);
995 1.102 fvdl pool_put(&lfs_dinode_pool, VTOI(vp)->i_din.ffs1_din);
996 1.84 perseant pool_put(&lfs_inoext_pool, ip->inode_ext.lfs);
997 1.84 perseant ip->inode_ext.lfs = NULL;
998 1.19 thorpej pool_put(&lfs_inode_pool, vp->v_data);
999 1.1 mycroft vp->v_data = NULL;
1000 1.94 perseant return (0);
1001 1.94 perseant }
1002 1.94 perseant
1003 1.94 perseant /*
1004 1.101 yamt * Read a block from a storage device.
1005 1.94 perseant * In order to avoid reading blocks that are in the process of being
1006 1.94 perseant * written by the cleaner---and hence are not mutexed by the normal
1007 1.94 perseant * buffer cache / page cache mechanisms---check for collisions before
1008 1.94 perseant * reading.
1009 1.94 perseant *
1010 1.94 perseant * We inline ufs_strategy to make sure that the VOP_BMAP occurs *before*
1011 1.94 perseant * the active cleaner test.
1012 1.94 perseant *
1013 1.94 perseant * XXX This code assumes that lfs_markv makes synchronous checkpoints.
1014 1.94 perseant */
1015 1.94 perseant int
1016 1.94 perseant lfs_strategy(void *v)
1017 1.94 perseant {
1018 1.94 perseant struct vop_strategy_args /* {
1019 1.94 perseant struct buf *a_bp;
1020 1.94 perseant } */ *ap = v;
1021 1.94 perseant struct buf *bp;
1022 1.94 perseant struct lfs *fs;
1023 1.94 perseant struct vnode *vp;
1024 1.94 perseant struct inode *ip;
1025 1.94 perseant daddr_t tbn;
1026 1.94 perseant int i, sn, error, slept;
1027 1.94 perseant
1028 1.94 perseant bp = ap->a_bp;
1029 1.94 perseant vp = bp->b_vp;
1030 1.94 perseant ip = VTOI(vp);
1031 1.94 perseant fs = ip->i_lfs;
1032 1.94 perseant
1033 1.101 yamt /* lfs uses its strategy routine only for read */
1034 1.101 yamt KASSERT(bp->b_flags & B_READ);
1035 1.101 yamt
1036 1.94 perseant if (vp->v_type == VBLK || vp->v_type == VCHR)
1037 1.94 perseant panic("lfs_strategy: spec");
1038 1.94 perseant KASSERT(bp->b_bcount != 0);
1039 1.94 perseant if (bp->b_blkno == bp->b_lblkno) {
1040 1.94 perseant error = VOP_BMAP(vp, bp->b_lblkno, NULL, &bp->b_blkno,
1041 1.94 perseant NULL);
1042 1.94 perseant if (error) {
1043 1.94 perseant bp->b_error = error;
1044 1.94 perseant bp->b_flags |= B_ERROR;
1045 1.94 perseant biodone(bp);
1046 1.94 perseant return (error);
1047 1.94 perseant }
1048 1.94 perseant if ((long)bp->b_blkno == -1) /* no valid data */
1049 1.94 perseant clrbuf(bp);
1050 1.94 perseant }
1051 1.94 perseant if ((long)bp->b_blkno < 0) { /* block is not on disk */
1052 1.94 perseant biodone(bp);
1053 1.94 perseant return (0);
1054 1.94 perseant }
1055 1.94 perseant
1056 1.94 perseant slept = 1;
1057 1.96 perseant simple_lock(&fs->lfs_interlock);
1058 1.101 yamt while (slept && fs->lfs_seglock) {
1059 1.96 perseant simple_unlock(&fs->lfs_interlock);
1060 1.94 perseant /*
1061 1.94 perseant * Look through list of intervals.
1062 1.94 perseant * There will only be intervals to look through
1063 1.94 perseant * if the cleaner holds the seglock.
1064 1.94 perseant * Since the cleaner is synchronous, we can trust
1065 1.94 perseant * the list of intervals to be current.
1066 1.94 perseant */
1067 1.94 perseant tbn = dbtofsb(fs, bp->b_blkno);
1068 1.94 perseant sn = dtosn(fs, tbn);
1069 1.94 perseant slept = 0;
1070 1.94 perseant for (i = 0; i < fs->lfs_cleanind; i++) {
1071 1.94 perseant if (sn == dtosn(fs, fs->lfs_cleanint[i]) &&
1072 1.94 perseant tbn >= fs->lfs_cleanint[i]) {
1073 1.94 perseant #ifdef DEBUG_LFS
1074 1.94 perseant printf("lfs_strategy: ino %d lbn %" PRId64
1075 1.94 perseant " ind %d sn %d fsb %" PRIx32
1076 1.94 perseant " given sn %d fsb %" PRIx64 "\n",
1077 1.94 perseant ip->i_number, bp->b_lblkno, i,
1078 1.94 perseant dtosn(fs, fs->lfs_cleanint[i]),
1079 1.94 perseant fs->lfs_cleanint[i], sn, tbn);
1080 1.94 perseant printf("lfs_strategy: sleeping on ino %d lbn %"
1081 1.94 perseant PRId64 "\n", ip->i_number, bp->b_lblkno);
1082 1.94 perseant #endif
1083 1.94 perseant tsleep(&fs->lfs_seglock, PRIBIO+1,
1084 1.94 perseant "lfs_strategy", 0);
1085 1.94 perseant /* Things may be different now; start over. */
1086 1.94 perseant slept = 1;
1087 1.94 perseant break;
1088 1.94 perseant }
1089 1.94 perseant }
1090 1.96 perseant simple_lock(&fs->lfs_interlock);
1091 1.94 perseant }
1092 1.96 perseant simple_unlock(&fs->lfs_interlock);
1093 1.94 perseant
1094 1.94 perseant vp = ip->i_devvp;
1095 1.94 perseant bp->b_dev = vp->v_rdev;
1096 1.94 perseant VOCALL (vp->v_op, VOFFSET(vop_strategy), ap);
1097 1.1 mycroft return (0);
1098 1.89 perseant }
1099 1.89 perseant
1100 1.92 perseant static void
1101 1.92 perseant lfs_flush_dirops(struct lfs *fs)
1102 1.92 perseant {
1103 1.92 perseant struct inode *ip, *nip;
1104 1.92 perseant struct vnode *vp;
1105 1.92 perseant extern int lfs_dostats;
1106 1.92 perseant struct segment *sp;
1107 1.92 perseant int needunlock;
1108 1.92 perseant
1109 1.92 perseant if (fs->lfs_ronly)
1110 1.92 perseant return;
1111 1.92 perseant
1112 1.92 perseant if (TAILQ_FIRST(&fs->lfs_dchainhd) == NULL)
1113 1.92 perseant return;
1114 1.92 perseant
1115 1.92 perseant /* XXX simplelock fs->lfs_dirops */
1116 1.92 perseant while (fs->lfs_dirops > 0) {
1117 1.92 perseant ++fs->lfs_diropwait;
1118 1.92 perseant tsleep(&fs->lfs_writer, PRIBIO+1, "pndirop", 0);
1119 1.92 perseant --fs->lfs_diropwait;
1120 1.92 perseant }
1121 1.92 perseant /* disallow dirops during flush */
1122 1.92 perseant fs->lfs_writer++;
1123 1.92 perseant
1124 1.92 perseant if (lfs_dostats)
1125 1.92 perseant ++lfs_stats.flush_invoked;
1126 1.92 perseant
1127 1.92 perseant /*
1128 1.92 perseant * Inline lfs_segwrite/lfs_writevnodes, but just for dirops.
1129 1.92 perseant * Technically this is a checkpoint (the on-disk state is valid)
1130 1.92 perseant * even though we are leaving out all the file data.
1131 1.92 perseant */
1132 1.92 perseant lfs_imtime(fs);
1133 1.92 perseant lfs_seglock(fs, SEGM_CKP);
1134 1.92 perseant sp = fs->lfs_sp;
1135 1.92 perseant
1136 1.92 perseant /*
1137 1.92 perseant * lfs_writevnodes, optimized to get dirops out of the way.
1138 1.92 perseant * Only write dirops, and don't flush files' pages, only
1139 1.92 perseant * blocks from the directories.
1140 1.92 perseant *
1141 1.92 perseant * We don't need to vref these files because they are
1142 1.92 perseant * dirops and so hold an extra reference until the
1143 1.92 perseant * segunlock clears them of that status.
1144 1.92 perseant *
1145 1.92 perseant * We don't need to check for IN_ADIROP because we know that
1146 1.92 perseant * no dirops are active.
1147 1.92 perseant *
1148 1.92 perseant */
1149 1.92 perseant for (ip = TAILQ_FIRST(&fs->lfs_dchainhd); ip != NULL; ip = nip) {
1150 1.92 perseant nip = TAILQ_NEXT(ip, i_lfs_dchain);
1151 1.92 perseant vp = ITOV(ip);
1152 1.92 perseant
1153 1.92 perseant /*
1154 1.92 perseant * All writes to directories come from dirops; all
1155 1.92 perseant * writes to files' direct blocks go through the page
1156 1.92 perseant * cache, which we're not touching. Reads to files
1157 1.92 perseant * and/or directories will not be affected by writing
1158 1.92 perseant * directory blocks inodes and file inodes. So we don't
1159 1.92 perseant * really need to lock. If we don't lock, though,
1160 1.92 perseant * make sure that we don't clear IN_MODIFIED
1161 1.92 perseant * unnecessarily.
1162 1.92 perseant */
1163 1.92 perseant if (vp->v_flag & VXLOCK)
1164 1.92 perseant continue;
1165 1.92 perseant if (vn_lock(vp, LK_EXCLUSIVE | LK_CANRECURSE |
1166 1.92 perseant LK_NOWAIT) == 0) {
1167 1.92 perseant needunlock = 1;
1168 1.92 perseant } else {
1169 1.92 perseant printf("lfs_flush_dirops: flushing locked ino %d\n",
1170 1.92 perseant VTOI(vp)->i_number);
1171 1.92 perseant needunlock = 0;
1172 1.92 perseant }
1173 1.92 perseant if (vp->v_type != VREG &&
1174 1.92 perseant ((ip->i_flag & IN_ALLMOD) || !VPISEMPTY(vp))) {
1175 1.92 perseant lfs_writefile(fs, sp, vp);
1176 1.92 perseant if (!VPISEMPTY(vp) && !WRITEINPROG(vp) &&
1177 1.92 perseant !(ip->i_flag & IN_ALLMOD)) {
1178 1.92 perseant LFS_SET_UINO(ip, IN_MODIFIED);
1179 1.92 perseant }
1180 1.92 perseant }
1181 1.92 perseant (void) lfs_writeinode(fs, sp, ip);
1182 1.92 perseant if (needunlock)
1183 1.92 perseant VOP_UNLOCK(vp, 0);
1184 1.92 perseant else
1185 1.92 perseant LFS_SET_UINO(ip, IN_MODIFIED);
1186 1.92 perseant }
1187 1.92 perseant /* We've written all the dirops there are */
1188 1.92 perseant ((SEGSUM *)(sp->segsum))->ss_flags &= ~(SS_CONT);
1189 1.92 perseant (void) lfs_writeseg(fs, sp);
1190 1.92 perseant lfs_segunlock(fs);
1191 1.92 perseant
1192 1.92 perseant if (--fs->lfs_writer == 0)
1193 1.92 perseant wakeup(&fs->lfs_dirops);
1194 1.92 perseant }
1195 1.92 perseant
1196 1.89 perseant /*
1197 1.90 perseant * Provide a fcntl interface to sys_lfs_{segwait,bmapv,markv}.
1198 1.89 perseant */
1199 1.89 perseant int
1200 1.90 perseant lfs_fcntl(void *v)
1201 1.89 perseant {
1202 1.90 perseant struct vop_fcntl_args /* {
1203 1.89 perseant struct vnode *a_vp;
1204 1.89 perseant u_long a_command;
1205 1.89 perseant caddr_t a_data;
1206 1.89 perseant int a_fflag;
1207 1.89 perseant struct ucred *a_cred;
1208 1.89 perseant struct proc *a_p;
1209 1.89 perseant } */ *ap = v;
1210 1.89 perseant struct timeval *tvp;
1211 1.89 perseant BLOCK_INFO *blkiov;
1212 1.92 perseant CLEANERINFO *cip;
1213 1.92 perseant int blkcnt, error, oclean;
1214 1.90 perseant struct lfs_fcntl_markv blkvp;
1215 1.89 perseant fsid_t *fsidp;
1216 1.92 perseant struct lfs *fs;
1217 1.92 perseant struct buf *bp;
1218 1.92 perseant daddr_t off;
1219 1.89 perseant
1220 1.90 perseant /* Only respect LFS fcntls on fs root or Ifile */
1221 1.89 perseant if (VTOI(ap->a_vp)->i_number != ROOTINO &&
1222 1.89 perseant VTOI(ap->a_vp)->i_number != LFS_IFILE_INUM) {
1223 1.90 perseant return ufs_fcntl(v);
1224 1.89 perseant }
1225 1.89 perseant
1226 1.100 perseant /* Avoid locking a draining lock */
1227 1.100 perseant if (ap->a_vp->v_mount->mnt_flag & MNT_UNMOUNT) {
1228 1.100 perseant return ESHUTDOWN;
1229 1.100 perseant }
1230 1.100 perseant
1231 1.100 perseant fs = VTOI(ap->a_vp)->i_lfs;
1232 1.89 perseant fsidp = &ap->a_vp->v_mount->mnt_stat.f_fsid;
1233 1.89 perseant
1234 1.98 perseant switch (ap->a_command) {
1235 1.90 perseant case LFCNSEGWAITALL:
1236 1.89 perseant fsidp = NULL;
1237 1.89 perseant /* FALLSTHROUGH */
1238 1.90 perseant case LFCNSEGWAIT:
1239 1.89 perseant tvp = (struct timeval *)ap->a_data;
1240 1.100 perseant simple_lock(&fs->lfs_interlock);
1241 1.100 perseant ++fs->lfs_sleepers;
1242 1.100 perseant simple_unlock(&fs->lfs_interlock);
1243 1.90 perseant VOP_UNLOCK(ap->a_vp, 0);
1244 1.100 perseant
1245 1.90 perseant error = lfs_segwait(fsidp, tvp);
1246 1.100 perseant
1247 1.90 perseant VOP_LOCK(ap->a_vp, LK_EXCLUSIVE);
1248 1.100 perseant simple_lock(&fs->lfs_interlock);
1249 1.100 perseant if (--fs->lfs_sleepers == 0)
1250 1.100 perseant wakeup(&fs->lfs_sleepers);
1251 1.100 perseant simple_unlock(&fs->lfs_interlock);
1252 1.90 perseant return error;
1253 1.89 perseant
1254 1.90 perseant case LFCNBMAPV:
1255 1.90 perseant case LFCNMARKV:
1256 1.89 perseant if ((error = suser(ap->a_p->p_ucred, &ap->a_p->p_acflag)) != 0)
1257 1.89 perseant return (error);
1258 1.90 perseant blkvp = *(struct lfs_fcntl_markv *)ap->a_data;
1259 1.89 perseant
1260 1.89 perseant blkcnt = blkvp.blkcnt;
1261 1.89 perseant if ((u_int) blkcnt > LFS_MARKV_MAXBLKCNT)
1262 1.89 perseant return (EINVAL);
1263 1.89 perseant blkiov = malloc(blkcnt * sizeof(BLOCK_INFO), M_SEGMENT, M_WAITOK);
1264 1.89 perseant if ((error = copyin(blkvp.blkiov, blkiov,
1265 1.89 perseant blkcnt * sizeof(BLOCK_INFO))) != 0) {
1266 1.89 perseant free(blkiov, M_SEGMENT);
1267 1.89 perseant return error;
1268 1.89 perseant }
1269 1.89 perseant
1270 1.100 perseant simple_lock(&fs->lfs_interlock);
1271 1.100 perseant ++fs->lfs_sleepers;
1272 1.100 perseant simple_unlock(&fs->lfs_interlock);
1273 1.90 perseant VOP_UNLOCK(ap->a_vp, 0);
1274 1.90 perseant if (ap->a_command == LFCNBMAPV)
1275 1.89 perseant error = lfs_bmapv(ap->a_p, fsidp, blkiov, blkcnt);
1276 1.90 perseant else /* LFCNMARKV */
1277 1.89 perseant error = lfs_markv(ap->a_p, fsidp, blkiov, blkcnt);
1278 1.89 perseant if (error == 0)
1279 1.89 perseant error = copyout(blkiov, blkvp.blkiov,
1280 1.89 perseant blkcnt * sizeof(BLOCK_INFO));
1281 1.90 perseant VOP_LOCK(ap->a_vp, LK_EXCLUSIVE);
1282 1.100 perseant simple_lock(&fs->lfs_interlock);
1283 1.100 perseant if (--fs->lfs_sleepers == 0)
1284 1.100 perseant wakeup(&fs->lfs_sleepers);
1285 1.100 perseant simple_unlock(&fs->lfs_interlock);
1286 1.89 perseant free(blkiov, M_SEGMENT);
1287 1.89 perseant return error;
1288 1.92 perseant
1289 1.92 perseant case LFCNRECLAIM:
1290 1.92 perseant /*
1291 1.92 perseant * Flush dirops and write Ifile, allowing empty segments
1292 1.92 perseant * to be immediately reclaimed.
1293 1.92 perseant */
1294 1.92 perseant off = fs->lfs_offset;
1295 1.92 perseant lfs_seglock(fs, SEGM_FORCE_CKP | SEGM_CKP);
1296 1.92 perseant lfs_flush_dirops(fs);
1297 1.92 perseant LFS_CLEANERINFO(cip, fs, bp);
1298 1.92 perseant oclean = cip->clean;
1299 1.92 perseant LFS_SYNC_CLEANERINFO(cip, fs, bp, 1);
1300 1.92 perseant lfs_segwrite(ap->a_vp->v_mount, SEGM_FORCE_CKP);
1301 1.92 perseant lfs_segunlock(fs);
1302 1.92 perseant
1303 1.92 perseant #ifdef DEBUG_LFS
1304 1.92 perseant LFS_CLEANERINFO(cip, fs, bp);
1305 1.92 perseant oclean = cip->clean;
1306 1.92 perseant printf("lfs_fcntl: reclaim wrote %" PRId64 " blocks, cleaned "
1307 1.92 perseant "%" PRId32 " segments (activesb %d)\n",
1308 1.92 perseant fs->lfs_offset - off, cip->clean - oclean,
1309 1.92 perseant fs->lfs_activesb);
1310 1.92 perseant LFS_SYNC_CLEANERINFO(cip, fs, bp, 0);
1311 1.92 perseant #endif
1312 1.92 perseant
1313 1.92 perseant return 0;
1314 1.89 perseant
1315 1.89 perseant default:
1316 1.90 perseant return ufs_fcntl(v);
1317 1.89 perseant }
1318 1.89 perseant return 0;
1319 1.60 chs }
1320 1.60 chs
1321 1.60 chs int
1322 1.60 chs lfs_getpages(void *v)
1323 1.60 chs {
1324 1.60 chs struct vop_getpages_args /* {
1325 1.60 chs struct vnode *a_vp;
1326 1.60 chs voff_t a_offset;
1327 1.60 chs struct vm_page **a_m;
1328 1.60 chs int *a_count;
1329 1.60 chs int a_centeridx;
1330 1.60 chs vm_prot_t a_access_type;
1331 1.60 chs int a_advice;
1332 1.60 chs int a_flags;
1333 1.60 chs } */ *ap = v;
1334 1.60 chs
1335 1.97 perseant if (VTOI(ap->a_vp)->i_number == LFS_IFILE_INUM &&
1336 1.97 perseant (ap->a_access_type & VM_PROT_WRITE) != 0) {
1337 1.97 perseant return EPERM;
1338 1.97 perseant }
1339 1.60 chs if ((ap->a_access_type & VM_PROT_WRITE) != 0) {
1340 1.60 chs LFS_SET_UINO(VTOI(ap->a_vp), IN_MODIFIED);
1341 1.60 chs }
1342 1.95 perseant return genfs_getpages(v);
1343 1.1 mycroft }
1344 1.84 perseant
1345 1.84 perseant /*
1346 1.84 perseant * Make sure that for all pages in every block in the given range,
1347 1.84 perseant * either all are dirty or all are clean. If any of the pages
1348 1.84 perseant * we've seen so far are dirty, put the vnode on the paging chain,
1349 1.84 perseant * and mark it IN_PAGING.
1350 1.84 perseant */
1351 1.84 perseant static int
1352 1.84 perseant check_dirty(struct lfs *fs, struct vnode *vp,
1353 1.84 perseant off_t startoffset, off_t endoffset, off_t blkeof,
1354 1.103 perseant int flags, int checkfirst)
1355 1.84 perseant {
1356 1.86 perseant int by_list;
1357 1.84 perseant struct vm_page *curpg, *pgs[MAXBSIZE / PAGE_SIZE], *pg;
1358 1.84 perseant struct lwp *l = curlwp ? curlwp : &lwp0;
1359 1.84 perseant off_t soff;
1360 1.84 perseant voff_t off;
1361 1.84 perseant int i, dirty, tdirty, nonexistent, any_dirty;
1362 1.84 perseant int pages_per_block = fs->lfs_bsize >> PAGE_SHIFT;
1363 1.84 perseant
1364 1.84 perseant top:
1365 1.84 perseant by_list = (vp->v_uobj.uo_npages <=
1366 1.84 perseant ((endoffset - startoffset) >> PAGE_SHIFT) *
1367 1.84 perseant UVM_PAGE_HASH_PENALTY);
1368 1.84 perseant any_dirty = 0;
1369 1.84 perseant
1370 1.84 perseant if (by_list) {
1371 1.84 perseant curpg = TAILQ_FIRST(&vp->v_uobj.memq);
1372 1.84 perseant PHOLD(l);
1373 1.84 perseant } else {
1374 1.84 perseant soff = startoffset;
1375 1.84 perseant }
1376 1.84 perseant while (by_list || soff < MIN(blkeof, endoffset)) {
1377 1.84 perseant if (by_list) {
1378 1.84 perseant if (pages_per_block > 1) {
1379 1.84 perseant while (curpg && (curpg->offset & fs->lfs_bmask))
1380 1.84 perseant curpg = TAILQ_NEXT(curpg, listq);
1381 1.84 perseant }
1382 1.84 perseant if (curpg == NULL)
1383 1.84 perseant break;
1384 1.84 perseant soff = curpg->offset;
1385 1.84 perseant }
1386 1.84 perseant
1387 1.84 perseant /*
1388 1.84 perseant * Mark all pages in extended range busy; find out if any
1389 1.84 perseant * of them are dirty.
1390 1.84 perseant */
1391 1.84 perseant nonexistent = dirty = 0;
1392 1.84 perseant for (i = 0; i == 0 || i < pages_per_block; i++) {
1393 1.84 perseant if (by_list && pages_per_block <= 1) {
1394 1.84 perseant pgs[i] = pg = curpg;
1395 1.84 perseant } else {
1396 1.84 perseant off = soff + (i << PAGE_SHIFT);
1397 1.84 perseant pgs[i] = pg = uvm_pagelookup(&vp->v_uobj, off);
1398 1.84 perseant if (pg == NULL) {
1399 1.84 perseant ++nonexistent;
1400 1.84 perseant continue;
1401 1.84 perseant }
1402 1.84 perseant }
1403 1.84 perseant KASSERT(pg != NULL);
1404 1.84 perseant while (pg->flags & PG_BUSY) {
1405 1.84 perseant pg->flags |= PG_WANTED;
1406 1.84 perseant UVM_UNLOCK_AND_WAIT(pg, &vp->v_interlock, 0,
1407 1.84 perseant "lfsput", 0);
1408 1.84 perseant simple_lock(&vp->v_interlock);
1409 1.96 perseant if (by_list) {
1410 1.96 perseant if (i > 0)
1411 1.96 perseant uvm_page_unbusy(pgs, i);
1412 1.84 perseant goto top;
1413 1.96 perseant }
1414 1.84 perseant }
1415 1.84 perseant pg->flags |= PG_BUSY;
1416 1.84 perseant UVM_PAGE_OWN(pg, "lfs_putpages");
1417 1.84 perseant
1418 1.84 perseant pmap_page_protect(pg, VM_PROT_NONE);
1419 1.84 perseant tdirty = (pmap_clear_modify(pg) ||
1420 1.84 perseant (pg->flags & PG_CLEAN) == 0);
1421 1.84 perseant dirty += tdirty;
1422 1.84 perseant }
1423 1.84 perseant if (pages_per_block > 0 && nonexistent >= pages_per_block) {
1424 1.84 perseant if (by_list) {
1425 1.84 perseant curpg = TAILQ_NEXT(curpg, listq);
1426 1.84 perseant } else {
1427 1.84 perseant soff += fs->lfs_bsize;
1428 1.84 perseant }
1429 1.84 perseant continue;
1430 1.84 perseant }
1431 1.84 perseant
1432 1.84 perseant any_dirty += dirty;
1433 1.84 perseant KASSERT(nonexistent == 0);
1434 1.84 perseant
1435 1.84 perseant /*
1436 1.84 perseant * If any are dirty make all dirty; unbusy them,
1437 1.88 perseant * but if we were asked to clean, wire them so that
1438 1.88 perseant * the pagedaemon doesn't bother us about them while
1439 1.88 perseant * they're on their way to disk.
1440 1.84 perseant */
1441 1.84 perseant for (i = 0; i == 0 || i < pages_per_block; i++) {
1442 1.84 perseant pg = pgs[i];
1443 1.84 perseant KASSERT(!((pg->flags & PG_CLEAN) && (pg->flags & PG_DELWRI)));
1444 1.84 perseant if (dirty) {
1445 1.84 perseant pg->flags &= ~PG_CLEAN;
1446 1.84 perseant if (flags & PGO_FREE) {
1447 1.84 perseant /* XXXUBC need better way to update */
1448 1.96 perseant simple_lock(&lfs_subsys_lock);
1449 1.84 perseant lfs_subsys_pages += MIN(1, pages_per_block);
1450 1.96 perseant simple_unlock(&lfs_subsys_lock);
1451 1.85 yamt /*
1452 1.96 perseant * Wire the page so that
1453 1.96 perseant * pdaemon doesn't see it again.
1454 1.85 yamt */
1455 1.84 perseant uvm_lock_pageq();
1456 1.85 yamt uvm_pagewire(pg);
1457 1.85 yamt uvm_unlock_pageq();
1458 1.88 perseant
1459 1.84 perseant /* Suspended write flag */
1460 1.84 perseant pg->flags |= PG_DELWRI;
1461 1.84 perseant }
1462 1.84 perseant }
1463 1.84 perseant if (pg->flags & PG_WANTED)
1464 1.84 perseant wakeup(pg);
1465 1.84 perseant pg->flags &= ~(PG_WANTED|PG_BUSY);
1466 1.85 yamt UVM_PAGE_OWN(pg, NULL);
1467 1.84 perseant }
1468 1.84 perseant
1469 1.103 perseant if (checkfirst && any_dirty)
1470 1.103 perseant return any_dirty;
1471 1.103 perseant
1472 1.84 perseant if (by_list) {
1473 1.84 perseant curpg = TAILQ_NEXT(curpg, listq);
1474 1.84 perseant } else {
1475 1.84 perseant soff += MAX(PAGE_SIZE, fs->lfs_bsize);
1476 1.84 perseant }
1477 1.84 perseant }
1478 1.84 perseant if (by_list) {
1479 1.84 perseant PRELE(l);
1480 1.84 perseant }
1481 1.84 perseant
1482 1.84 perseant /*
1483 1.84 perseant * If any pages were dirty, mark this inode as "pageout requested",
1484 1.84 perseant * and put it on the paging queue.
1485 1.84 perseant * XXXUBC locking (check locking on dchainhd too)
1486 1.84 perseant */
1487 1.84 perseant #ifdef notyet
1488 1.84 perseant if (any_dirty) {
1489 1.84 perseant if (!(ip->i_flags & IN_PAGING)) {
1490 1.84 perseant ip->i_flags |= IN_PAGING;
1491 1.84 perseant TAILQ_INSERT_TAIL(&fs->lfs_pchainhd, ip, i_lfs_pchain);
1492 1.84 perseant }
1493 1.84 perseant }
1494 1.84 perseant #endif
1495 1.84 perseant return any_dirty;
1496 1.84 perseant }
1497 1.84 perseant
1498 1.84 perseant /*
1499 1.84 perseant * lfs_putpages functions like genfs_putpages except that
1500 1.84 perseant *
1501 1.84 perseant * (1) It needs to bounds-check the incoming requests to ensure that
1502 1.84 perseant * they are block-aligned; if they are not, expand the range and
1503 1.84 perseant * do the right thing in case, e.g., the requested range is clean
1504 1.84 perseant * but the expanded range is dirty.
1505 1.84 perseant * (2) It needs to explicitly send blocks to be written when it is done.
1506 1.84 perseant * VOP_PUTPAGES is not ever called with the seglock held, so
1507 1.84 perseant * we simply take the seglock and let lfs_segunlock wait for us.
1508 1.84 perseant * XXX Actually we can be called with the seglock held, if we have
1509 1.84 perseant * XXX to flush a vnode while lfs_markv is in operation. As of this
1510 1.84 perseant * XXX writing we panic in this case.
1511 1.84 perseant *
1512 1.84 perseant * Assumptions:
1513 1.84 perseant *
1514 1.84 perseant * (1) The caller does not hold any pages in this vnode busy. If it does,
1515 1.84 perseant * there is a danger that when we expand the page range and busy the
1516 1.84 perseant * pages we will deadlock.
1517 1.84 perseant * (2) We are called with vp->v_interlock held; we must return with it
1518 1.84 perseant * released.
1519 1.84 perseant * (3) We don't absolutely have to free pages right away, provided that
1520 1.84 perseant * the request does not have PGO_SYNCIO. When the pagedaemon gives
1521 1.84 perseant * us a request with PGO_FREE, we take the pages out of the paging
1522 1.84 perseant * queue and wake up the writer, which will handle freeing them for us.
1523 1.84 perseant *
1524 1.84 perseant * We ensure that for any filesystem block, all pages for that
1525 1.84 perseant * block are either resident or not, even if those pages are higher
1526 1.84 perseant * than EOF; that means that we will be getting requests to free
1527 1.84 perseant * "unused" pages above EOF all the time, and should ignore them.
1528 1.84 perseant */
1529 1.84 perseant
1530 1.84 perseant int
1531 1.84 perseant lfs_putpages(void *v)
1532 1.84 perseant {
1533 1.84 perseant int error;
1534 1.84 perseant struct vop_putpages_args /* {
1535 1.84 perseant struct vnode *a_vp;
1536 1.84 perseant voff_t a_offlo;
1537 1.84 perseant voff_t a_offhi;
1538 1.84 perseant int a_flags;
1539 1.84 perseant } */ *ap = v;
1540 1.84 perseant struct vnode *vp;
1541 1.84 perseant struct inode *ip;
1542 1.84 perseant struct lfs *fs;
1543 1.84 perseant struct segment *sp;
1544 1.84 perseant off_t origoffset, startoffset, endoffset, origendoffset, blkeof;
1545 1.95 perseant off_t off, max_endoffset;
1546 1.84 perseant int pages_per_block;
1547 1.84 perseant int s, sync, dirty, pagedaemon;
1548 1.95 perseant struct vm_page *pg;
1549 1.84 perseant UVMHIST_FUNC("lfs_putpages"); UVMHIST_CALLED(ubchist);
1550 1.84 perseant
1551 1.84 perseant vp = ap->a_vp;
1552 1.84 perseant ip = VTOI(vp);
1553 1.84 perseant fs = ip->i_lfs;
1554 1.84 perseant sync = (ap->a_flags & PGO_SYNCIO);
1555 1.84 perseant pagedaemon = (curproc == uvm.pagedaemon_proc);
1556 1.84 perseant
1557 1.84 perseant /* Putpages does nothing for metadata. */
1558 1.84 perseant if (vp == fs->lfs_ivnode || vp->v_type != VREG) {
1559 1.84 perseant simple_unlock(&vp->v_interlock);
1560 1.84 perseant return 0;
1561 1.84 perseant }
1562 1.84 perseant
1563 1.84 perseant /*
1564 1.84 perseant * If there are no pages, don't do anything.
1565 1.84 perseant */
1566 1.84 perseant if (vp->v_uobj.uo_npages == 0) {
1567 1.84 perseant s = splbio();
1568 1.84 perseant if (LIST_FIRST(&vp->v_dirtyblkhd) == NULL &&
1569 1.84 perseant (vp->v_flag & VONWORKLST)) {
1570 1.84 perseant vp->v_flag &= ~VONWORKLST;
1571 1.84 perseant LIST_REMOVE(vp, v_synclist);
1572 1.84 perseant }
1573 1.84 perseant splx(s);
1574 1.84 perseant simple_unlock(&vp->v_interlock);
1575 1.84 perseant return 0;
1576 1.84 perseant }
1577 1.84 perseant
1578 1.102 fvdl blkeof = blkroundup(fs, ip->i_size);
1579 1.84 perseant
1580 1.84 perseant /*
1581 1.84 perseant * Ignore requests to free pages past EOF but in the same block
1582 1.84 perseant * as EOF, unless the request is synchronous. (XXX why sync?)
1583 1.84 perseant * XXXUBC Make these pages look "active" so the pagedaemon won't
1584 1.84 perseant * XXXUBC bother us with them again.
1585 1.84 perseant */
1586 1.102 fvdl if (!sync && ap->a_offlo >= ip->i_size && ap->a_offlo < blkeof) {
1587 1.84 perseant origoffset = ap->a_offlo;
1588 1.95 perseant for (off = origoffset; off < blkeof; off += fs->lfs_bsize) {
1589 1.95 perseant pg = uvm_pagelookup(&vp->v_uobj, off);
1590 1.95 perseant KASSERT(pg != NULL);
1591 1.95 perseant while (pg->flags & PG_BUSY) {
1592 1.95 perseant pg->flags |= PG_WANTED;
1593 1.95 perseant UVM_UNLOCK_AND_WAIT(pg, &vp->v_interlock, 0,
1594 1.95 perseant "lfsput2", 0);
1595 1.95 perseant simple_lock(&vp->v_interlock);
1596 1.95 perseant }
1597 1.95 perseant uvm_lock_pageq();
1598 1.95 perseant uvm_pageactivate(pg);
1599 1.95 perseant uvm_unlock_pageq();
1600 1.95 perseant }
1601 1.84 perseant ap->a_offlo = blkeof;
1602 1.84 perseant if (ap->a_offhi > 0 && ap->a_offhi <= ap->a_offlo) {
1603 1.84 perseant simple_unlock(&vp->v_interlock);
1604 1.84 perseant return 0;
1605 1.84 perseant }
1606 1.84 perseant }
1607 1.84 perseant
1608 1.84 perseant /*
1609 1.84 perseant * Extend page range to start and end at block boundaries.
1610 1.84 perseant * (For the purposes of VOP_PUTPAGES, fragments don't exist.)
1611 1.84 perseant */
1612 1.84 perseant pages_per_block = fs->lfs_bsize >> PAGE_SHIFT;
1613 1.86 perseant origoffset = ap->a_offlo;
1614 1.84 perseant origendoffset = ap->a_offhi;
1615 1.86 perseant startoffset = origoffset & ~(fs->lfs_bmask);
1616 1.84 perseant max_endoffset = (trunc_page(LLONG_MAX) >> fs->lfs_bshift)
1617 1.84 perseant << fs->lfs_bshift;
1618 1.84 perseant
1619 1.84 perseant if (origendoffset == 0 || ap->a_flags & PGO_ALLPAGES) {
1620 1.86 perseant endoffset = max_endoffset;
1621 1.84 perseant origendoffset = endoffset;
1622 1.86 perseant } else {
1623 1.84 perseant origendoffset = round_page(ap->a_offhi);
1624 1.84 perseant endoffset = round_page(blkroundup(fs, origendoffset));
1625 1.84 perseant }
1626 1.84 perseant
1627 1.84 perseant KASSERT(startoffset > 0 || endoffset >= startoffset);
1628 1.84 perseant if (startoffset == endoffset) {
1629 1.84 perseant /* Nothing to do, why were we called? */
1630 1.84 perseant simple_unlock(&vp->v_interlock);
1631 1.84 perseant #ifdef DEBUG
1632 1.84 perseant printf("lfs_putpages: startoffset = endoffset = %" PRId64 "\n",
1633 1.84 perseant startoffset);
1634 1.84 perseant #endif
1635 1.84 perseant return 0;
1636 1.84 perseant }
1637 1.84 perseant
1638 1.84 perseant ap->a_offlo = startoffset;
1639 1.84 perseant ap->a_offhi = endoffset;
1640 1.84 perseant
1641 1.84 perseant if (!(ap->a_flags & PGO_CLEANIT))
1642 1.84 perseant return genfs_putpages(v);
1643 1.84 perseant
1644 1.84 perseant /*
1645 1.103 perseant * If there are more than one page per block, we don't want
1646 1.103 perseant * to get caught locking them backwards; so set PGO_BUSYFAIL
1647 1.103 perseant * to avoid deadlocks.
1648 1.84 perseant */
1649 1.103 perseant ap->a_flags |= PGO_BUSYFAIL;
1650 1.103 perseant
1651 1.103 perseant do {
1652 1.103 perseant int r;
1653 1.103 perseant
1654 1.103 perseant /* If no pages are dirty, we can just use genfs_getpages. */
1655 1.103 perseant if ((dirty = check_dirty(fs, vp, startoffset, endoffset, blkeof,
1656 1.103 perseant ap->a_flags, 1)) != 0)
1657 1.103 perseant break;
1658 1.103 perseant
1659 1.103 perseant if ((r = genfs_putpages(v)) != EDEADLK)
1660 1.103 perseant return r;
1661 1.103 perseant
1662 1.103 perseant /* Start over. */
1663 1.103 perseant preempt(NULL);
1664 1.103 perseant simple_lock(&vp->v_interlock);
1665 1.103 perseant } while(1);
1666 1.84 perseant
1667 1.84 perseant /*
1668 1.84 perseant * Dirty and asked to clean.
1669 1.84 perseant *
1670 1.84 perseant * Pagedaemon can't actually write LFS pages; wake up
1671 1.84 perseant * the writer to take care of that. The writer will
1672 1.84 perseant * notice the pager inode queue and act on that.
1673 1.84 perseant */
1674 1.84 perseant if (pagedaemon) {
1675 1.84 perseant ++fs->lfs_pdflush;
1676 1.84 perseant wakeup(&lfs_writer_daemon);
1677 1.87 yamt simple_unlock(&vp->v_interlock);
1678 1.84 perseant return EWOULDBLOCK;
1679 1.84 perseant }
1680 1.84 perseant
1681 1.84 perseant /*
1682 1.84 perseant * If this is a file created in a recent dirop, we can't flush its
1683 1.84 perseant * inode until the dirop is complete. Drain dirops, then flush the
1684 1.84 perseant * filesystem (taking care of any other pending dirops while we're
1685 1.84 perseant * at it).
1686 1.84 perseant */
1687 1.84 perseant if ((ap->a_flags & (PGO_CLEANIT|PGO_LOCKED)) == PGO_CLEANIT &&
1688 1.84 perseant (vp->v_flag & VDIROP)) {
1689 1.84 perseant int locked;
1690 1.84 perseant
1691 1.84 perseant /* printf("putpages to clean VDIROP, flushing\n"); */
1692 1.84 perseant while (fs->lfs_dirops > 0) {
1693 1.84 perseant ++fs->lfs_diropwait;
1694 1.84 perseant tsleep(&fs->lfs_writer, PRIBIO+1, "ppdirop", 0);
1695 1.84 perseant --fs->lfs_diropwait;
1696 1.84 perseant }
1697 1.84 perseant ++fs->lfs_writer;
1698 1.84 perseant locked = VOP_ISLOCKED(vp) && /* XXX */
1699 1.84 perseant vp->v_lock.lk_lockholder == curproc->p_pid;
1700 1.84 perseant if (locked)
1701 1.84 perseant VOP_UNLOCK(vp, 0);
1702 1.84 perseant simple_unlock(&vp->v_interlock);
1703 1.84 perseant
1704 1.84 perseant lfs_flush_fs(fs, sync ? SEGM_SYNC : 0);
1705 1.84 perseant
1706 1.84 perseant simple_lock(&vp->v_interlock);
1707 1.84 perseant if (locked)
1708 1.84 perseant VOP_LOCK(vp, LK_EXCLUSIVE);
1709 1.84 perseant if (--fs->lfs_writer == 0)
1710 1.84 perseant wakeup(&fs->lfs_dirops);
1711 1.84 perseant
1712 1.84 perseant /* XXX the flush should have taken care of this one too! */
1713 1.84 perseant }
1714 1.84 perseant
1715 1.84 perseant /*
1716 1.86 perseant * This is it. We are going to write some pages. From here on
1717 1.84 perseant * down it's all just mechanics.
1718 1.84 perseant *
1719 1.103 perseant * Don't let genfs_putpages wait; lfs_segunlock will wait for us.
1720 1.84 perseant */
1721 1.84 perseant ap->a_flags &= ~PGO_SYNCIO;
1722 1.84 perseant
1723 1.84 perseant /*
1724 1.84 perseant * If we've already got the seglock, flush the node and return.
1725 1.84 perseant * The FIP has already been set up for us by lfs_writefile,
1726 1.84 perseant * and FIP cleanup and lfs_updatemeta will also be done there,
1727 1.84 perseant * unless genfs_putpages returns EDEADLK; then we must flush
1728 1.84 perseant * what we have, and correct FIP and segment header accounting.
1729 1.84 perseant */
1730 1.84 perseant if (ap->a_flags & PGO_LOCKED) {
1731 1.84 perseant sp = fs->lfs_sp;
1732 1.84 perseant sp->vp = vp;
1733 1.84 perseant
1734 1.103 perseant /*
1735 1.103 perseant * Make sure that all pages in any given block are dirty, or
1736 1.103 perseant * none of them are.
1737 1.103 perseant */
1738 1.103 perseant again:
1739 1.103 perseant check_dirty(fs, vp, startoffset, endoffset, blkeof,
1740 1.103 perseant ap->a_flags, 1);
1741 1.103 perseant
1742 1.103 perseant if ((error = genfs_putpages(v)) == EDEADLK) {
1743 1.84 perseant #ifdef DEBUG_LFS
1744 1.84 perseant printf("lfs_putpages: genfs_putpages returned EDEADLK"
1745 1.84 perseant " ino %d off %x (seg %d)\n",
1746 1.84 perseant ip->i_number, fs->lfs_offset,
1747 1.84 perseant dtosn(fs, fs->lfs_offset));
1748 1.84 perseant #endif
1749 1.88 perseant /* If nothing to write, short-circuit */
1750 1.88 perseant if (sp->cbpp - sp->bpp == 1) {
1751 1.88 perseant preempt(NULL);
1752 1.88 perseant simple_lock(&vp->v_interlock);
1753 1.103 perseant goto again;
1754 1.88 perseant }
1755 1.84 perseant /* Write gathered pages */
1756 1.86 perseant lfs_updatemeta(sp);
1757 1.86 perseant (void) lfs_writeseg(fs, sp);
1758 1.84 perseant
1759 1.84 perseant /* Reinitialize brand new FIP and add us to it */
1760 1.84 perseant sp->vp = vp;
1761 1.102 fvdl sp->fip->fi_version = ip->i_gen;
1762 1.86 perseant sp->fip->fi_ino = ip->i_number;
1763 1.86 perseant /* Add us to the new segment summary. */
1764 1.86 perseant ++((SEGSUM *)(sp->segsum))->ss_nfinfo;
1765 1.86 perseant sp->sum_bytes_left -=
1766 1.86 perseant sizeof(struct finfo) - sizeof(int32_t);
1767 1.84 perseant
1768 1.84 perseant /* Give the write a chance to complete */
1769 1.84 perseant preempt(NULL);
1770 1.103 perseant
1771 1.103 perseant /* We've lost the interlock. Start over. */
1772 1.84 perseant simple_lock(&vp->v_interlock);
1773 1.103 perseant goto again;
1774 1.84 perseant }
1775 1.103 perseant lfs_updatemeta(sp);
1776 1.84 perseant return error;
1777 1.84 perseant }
1778 1.84 perseant
1779 1.87 yamt simple_unlock(&vp->v_interlock);
1780 1.84 perseant /*
1781 1.84 perseant * Take the seglock, because we are going to be writing pages.
1782 1.84 perseant */
1783 1.84 perseant if ((error = lfs_seglock(fs, SEGM_PROT | (sync ? SEGM_SYNC : 0))) != 0)
1784 1.84 perseant return error;
1785 1.84 perseant
1786 1.84 perseant /*
1787 1.84 perseant * VOP_PUTPAGES should not be called while holding the seglock.
1788 1.93 perseant * XXXUBC fix lfs_markv, or do this properly.
1789 1.84 perseant */
1790 1.93 perseant /* KASSERT(fs->lfs_seglock == 1); */
1791 1.84 perseant
1792 1.84 perseant /*
1793 1.84 perseant * We assume we're being called with sp->fip pointing at blank space.
1794 1.84 perseant * Account for a new FIP in the segment header, and set sp->vp.
1795 1.84 perseant * (This should duplicate the setup at the top of lfs_writefile().)
1796 1.84 perseant */
1797 1.84 perseant sp = fs->lfs_sp;
1798 1.86 perseant if (sp->seg_bytes_left < fs->lfs_bsize ||
1799 1.86 perseant sp->sum_bytes_left < sizeof(struct finfo))
1800 1.86 perseant (void) lfs_writeseg(fs, fs->lfs_sp);
1801 1.84 perseant
1802 1.86 perseant sp->sum_bytes_left -= sizeof(struct finfo) - sizeof(int32_t);
1803 1.86 perseant ++((SEGSUM *)(sp->segsum))->ss_nfinfo;
1804 1.84 perseant sp->vp = vp;
1805 1.84 perseant
1806 1.86 perseant if (vp->v_flag & VDIROP)
1807 1.86 perseant ((SEGSUM *)(sp->segsum))->ss_flags |= (SS_DIROP|SS_CONT);
1808 1.84 perseant
1809 1.86 perseant sp->fip->fi_nblocks = 0;
1810 1.86 perseant sp->fip->fi_ino = ip->i_number;
1811 1.102 fvdl sp->fip->fi_version = ip->i_gen;
1812 1.84 perseant
1813 1.84 perseant /*
1814 1.84 perseant * Loop through genfs_putpages until all pages are gathered.
1815 1.88 perseant * genfs_putpages() drops the interlock, so reacquire it if necessary.
1816 1.103 perseant * Whenever we lose the interlock we have to rerun check_dirty, as
1817 1.103 perseant * well.
1818 1.84 perseant */
1819 1.103 perseant again2:
1820 1.87 yamt simple_lock(&vp->v_interlock);
1821 1.103 perseant check_dirty(fs, vp, startoffset, endoffset, blkeof, ap->a_flags, 1);
1822 1.103 perseant
1823 1.103 perseant if ((error = genfs_putpages(v)) == EDEADLK) {
1824 1.84 perseant #ifdef DEBUG_LFS
1825 1.84 perseant printf("lfs_putpages: genfs_putpages returned EDEADLK [2]"
1826 1.84 perseant " ino %d off %x (seg %d)\n",
1827 1.84 perseant ip->i_number, fs->lfs_offset,
1828 1.84 perseant dtosn(fs, fs->lfs_offset));
1829 1.84 perseant #endif
1830 1.88 perseant /* If nothing to write, short-circuit */
1831 1.88 perseant if (sp->cbpp - sp->bpp == 1) {
1832 1.88 perseant preempt(NULL);
1833 1.103 perseant goto again2;
1834 1.88 perseant }
1835 1.84 perseant /* Write gathered pages */
1836 1.86 perseant lfs_updatemeta(sp);
1837 1.86 perseant (void) lfs_writeseg(fs, sp);
1838 1.84 perseant
1839 1.84 perseant /*
1840 1.84 perseant * Reinitialize brand new FIP and add us to it.
1841 1.84 perseant * (This should duplicate the fixup in lfs_gatherpages().)
1842 1.84 perseant */
1843 1.84 perseant sp->vp = vp;
1844 1.102 fvdl sp->fip->fi_version = ip->i_gen;
1845 1.86 perseant sp->fip->fi_ino = ip->i_number;
1846 1.86 perseant /* Add us to the new segment summary. */
1847 1.86 perseant ++((SEGSUM *)(sp->segsum))->ss_nfinfo;
1848 1.86 perseant sp->sum_bytes_left -=
1849 1.86 perseant sizeof(struct finfo) - sizeof(int32_t);
1850 1.84 perseant
1851 1.84 perseant /* Give the write a chance to complete */
1852 1.84 perseant preempt(NULL);
1853 1.103 perseant
1854 1.103 perseant /* We've lost the interlock. Start over. */
1855 1.103 perseant goto again2;
1856 1.84 perseant }
1857 1.103 perseant
1858 1.103 perseant /* Write indirect blocks as well */
1859 1.103 perseant lfs_gather(fs, fs->lfs_sp, vp, lfs_match_indir);
1860 1.103 perseant lfs_gather(fs, fs->lfs_sp, vp, lfs_match_dindir);
1861 1.103 perseant lfs_gather(fs, fs->lfs_sp, vp, lfs_match_tindir);
1862 1.84 perseant
1863 1.84 perseant /*
1864 1.84 perseant * Blocks are now gathered into a segment waiting to be written.
1865 1.84 perseant * All that's left to do is update metadata, and write them.
1866 1.84 perseant */
1867 1.84 perseant lfs_updatemeta(fs->lfs_sp);
1868 1.84 perseant fs->lfs_sp->vp = NULL;
1869 1.84 perseant /*
1870 1.88 perseant * Clean up FIP, since we're done writing this file.
1871 1.88 perseant * This should duplicate cleanup at the end of lfs_writefile().
1872 1.84 perseant */
1873 1.86 perseant if (sp->fip->fi_nblocks != 0) {
1874 1.86 perseant sp->fip = (FINFO*)((caddr_t)sp->fip + sizeof(struct finfo) +
1875 1.84 perseant sizeof(int32_t) * (sp->fip->fi_nblocks - 1));
1876 1.86 perseant sp->start_lbp = &sp->fip->fi_blocks[0];
1877 1.86 perseant } else {
1878 1.86 perseant sp->sum_bytes_left += sizeof(FINFO) - sizeof(int32_t);
1879 1.86 perseant --((SEGSUM *)(sp->segsum))->ss_nfinfo;
1880 1.86 perseant }
1881 1.88 perseant lfs_writeseg(fs, fs->lfs_sp);
1882 1.88 perseant
1883 1.84 perseant /*
1884 1.84 perseant * XXX - with the malloc/copy writeseg, the pages are freed by now
1885 1.84 perseant * even if we don't wait (e.g. if we hold a nested lock). This
1886 1.84 perseant * will not be true if we stop using malloc/copy.
1887 1.84 perseant */
1888 1.84 perseant KASSERT(fs->lfs_sp->seg_flags & SEGM_PROT);
1889 1.84 perseant lfs_segunlock(fs);
1890 1.84 perseant
1891 1.84 perseant /*
1892 1.84 perseant * Wait for v_numoutput to drop to zero. The seglock should
1893 1.84 perseant * take care of this, but there is a slight possibility that
1894 1.84 perseant * aiodoned might not have got around to our buffers yet.
1895 1.84 perseant */
1896 1.84 perseant if (sync) {
1897 1.84 perseant int s;
1898 1.84 perseant
1899 1.84 perseant s = splbio();
1900 1.84 perseant simple_lock(&global_v_numoutput_slock);
1901 1.98 perseant while (vp->v_numoutput > 0) {
1902 1.84 perseant #ifdef DEBUG
1903 1.84 perseant printf("ino %d sleeping on num %d\n",
1904 1.84 perseant ip->i_number, vp->v_numoutput);
1905 1.84 perseant #endif
1906 1.84 perseant vp->v_flag |= VBWAIT;
1907 1.87 yamt ltsleep(&vp->v_numoutput, PRIBIO + 1, "lfs_vn", 0,
1908 1.87 yamt &global_v_numoutput_slock);
1909 1.84 perseant }
1910 1.84 perseant simple_unlock(&global_v_numoutput_slock);
1911 1.84 perseant splx(s);
1912 1.84 perseant }
1913 1.84 perseant return error;
1914 1.84 perseant }
1915 1.84 perseant
1916 1.84 perseant /*
1917 1.84 perseant * Return the last logical file offset that should be written for this file
1918 1.86 perseant * if we're doing a write that ends at "size". If writing, we need to know
1919 1.84 perseant * about sizes on disk, i.e. fragments if there are any; if reading, we need
1920 1.84 perseant * to know about entire blocks.
1921 1.84 perseant */
1922 1.84 perseant void
1923 1.84 perseant lfs_gop_size(struct vnode *vp, off_t size, off_t *eobp, int flags)
1924 1.84 perseant {
1925 1.84 perseant struct inode *ip = VTOI(vp);
1926 1.84 perseant struct lfs *fs = ip->i_lfs;
1927 1.84 perseant daddr_t olbn, nlbn;
1928 1.84 perseant
1929 1.84 perseant KASSERT(flags & (GOP_SIZE_READ | GOP_SIZE_WRITE));
1930 1.84 perseant KASSERT((flags & (GOP_SIZE_READ | GOP_SIZE_WRITE))
1931 1.84 perseant != (GOP_SIZE_READ | GOP_SIZE_WRITE));
1932 1.84 perseant
1933 1.102 fvdl olbn = lblkno(fs, ip->i_size);
1934 1.84 perseant nlbn = lblkno(fs, size);
1935 1.86 perseant if ((flags & GOP_SIZE_WRITE) && nlbn < NDADDR && olbn <= nlbn) {
1936 1.86 perseant *eobp = fragroundup(fs, size);
1937 1.86 perseant } else {
1938 1.86 perseant *eobp = blkroundup(fs, size);
1939 1.86 perseant }
1940 1.84 perseant }
1941 1.84 perseant
1942 1.84 perseant #ifdef DEBUG
1943 1.84 perseant void lfs_dump_vop(void *);
1944 1.84 perseant
1945 1.84 perseant void
1946 1.84 perseant lfs_dump_vop(void *v)
1947 1.84 perseant {
1948 1.86 perseant struct vop_putpages_args /* {
1949 1.86 perseant struct vnode *a_vp;
1950 1.86 perseant voff_t a_offlo;
1951 1.86 perseant voff_t a_offhi;
1952 1.86 perseant int a_flags;
1953 1.86 perseant } */ *ap = v;
1954 1.84 perseant
1955 1.84 perseant vfs_vnode_print(ap->a_vp, 0, printf);
1956 1.102 fvdl lfs_dump_dinode(VTOI(ap->a_vp)->i_din.ffs1_din);
1957 1.84 perseant }
1958 1.84 perseant #endif
1959 1.84 perseant
1960 1.84 perseant int
1961 1.84 perseant lfs_mmap(void *v)
1962 1.84 perseant {
1963 1.84 perseant struct vop_mmap_args /* {
1964 1.86 perseant const struct vnodeop_desc *a_desc;
1965 1.86 perseant struct vnode *a_vp;
1966 1.86 perseant int a_fflags;
1967 1.86 perseant struct ucred *a_cred;
1968 1.86 perseant struct proc *a_p;
1969 1.84 perseant } */ *ap = v;
1970 1.84 perseant
1971 1.84 perseant if (VTOI(ap->a_vp)->i_number == LFS_IFILE_INUM)
1972 1.84 perseant return EOPNOTSUPP;
1973 1.84 perseant return ufs_mmap(v);
1974 1.84 perseant }
1975