lfs_vnops.c revision 1.96 1 1.96 perseant /* $NetBSD: lfs_vnops.c,v 1.96 2003/03/15 06:58:51 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.96 perseant __KERNEL_RCSID(0, "$NetBSD: lfs_vnops.c,v 1.96 2003/03/15 06:58:51 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.84 perseant do {
319 1.63 perseant #ifdef DEBUG
320 1.86 perseant struct buf *bp;
321 1.84 perseant #endif
322 1.63 perseant
323 1.84 perseant simple_lock(&vp->v_interlock);
324 1.84 perseant error = VOP_PUTPAGES(vp, trunc_page(ap->a_offlo),
325 1.86 perseant round_page(ap->a_offhi),
326 1.86 perseant PGO_CLEANIT | (wait ? PGO_SYNCIO : 0));
327 1.84 perseant if (error)
328 1.84 perseant return error;
329 1.84 perseant error = VOP_UPDATE(vp, NULL, NULL, wait ? UPDATE_WAIT : 0);
330 1.84 perseant if (wait && error == 0 && !VPISEMPTY(vp)) {
331 1.84 perseant #ifdef DEBUG
332 1.84 perseant printf("lfs_fsync: reflushing ino %d\n",
333 1.84 perseant VTOI(vp)->i_number);
334 1.84 perseant printf("vflags %x iflags %x npages %d\n",
335 1.84 perseant vp->v_flag, VTOI(vp)->i_flag,
336 1.84 perseant vp->v_uobj.uo_npages);
337 1.84 perseant LIST_FOREACH(bp, &vp->v_dirtyblkhd, b_vnbufs)
338 1.84 perseant printf("%" PRId64 " (%lx)", bp->b_lblkno,
339 1.84 perseant bp->b_flags);
340 1.84 perseant printf("\n");
341 1.63 perseant #endif
342 1.96 perseant LFS_SET_UINO(VTOI(vp), IN_MODIFIED);
343 1.84 perseant }
344 1.84 perseant } while (wait && error == 0 && !VPISEMPTY(vp));
345 1.84 perseant
346 1.63 perseant return error;
347 1.1 mycroft }
348 1.1 mycroft
349 1.1 mycroft /*
350 1.40 perseant * Take IN_ADIROP off, then call ufs_inactive.
351 1.40 perseant */
352 1.40 perseant int
353 1.51 perseant lfs_inactive(void *v)
354 1.40 perseant {
355 1.40 perseant struct vop_inactive_args /* {
356 1.40 perseant struct vnode *a_vp;
357 1.40 perseant struct proc *a_p;
358 1.40 perseant } */ *ap = v;
359 1.72 yamt
360 1.77 yamt KASSERT(VTOI(ap->a_vp)->i_ffs_nlink == VTOI(ap->a_vp)->i_ffs_effnlink);
361 1.77 yamt
362 1.76 yamt lfs_unmark_vnode(ap->a_vp);
363 1.76 yamt
364 1.75 yamt return ufs_inactive(v);
365 1.40 perseant }
366 1.40 perseant
367 1.40 perseant /*
368 1.1 mycroft * These macros are used to bracket UFS directory ops, so that we can
369 1.1 mycroft * identify all the pages touched during directory ops which need to
370 1.1 mycroft * be ordered and flushed atomically, so that they may be recovered.
371 1.1 mycroft */
372 1.22 perseant /*
373 1.22 perseant * XXX KS - Because we have to mark nodes VDIROP in order to prevent
374 1.22 perseant * the cache from reclaiming them while a dirop is in progress, we must
375 1.22 perseant * also manage the number of nodes so marked (otherwise we can run out).
376 1.22 perseant * We do this by setting lfs_dirvcount to the number of marked vnodes; it
377 1.22 perseant * is decremented during segment write, when VDIROP is taken off.
378 1.22 perseant */
379 1.71 yamt #define SET_DIROP(vp) SET_DIROP2((vp), NULL)
380 1.71 yamt #define SET_DIROP2(vp, vp2) lfs_set_dirop((vp), (vp2))
381 1.71 yamt static int lfs_set_dirop(struct vnode *, struct vnode *);
382 1.31 perseant extern int lfs_dirvcount;
383 1.84 perseant extern int lfs_do_flush;
384 1.24 perseant
385 1.70 yamt #define NRESERVE(fs) (btofsb(fs, (NIADDR + 3 + (2 * NIADDR + 3)) << fs->lfs_bshift))
386 1.70 yamt
387 1.46 perseant static int
388 1.71 yamt lfs_set_dirop(struct vnode *vp, struct vnode *vp2)
389 1.40 perseant {
390 1.24 perseant struct lfs *fs;
391 1.24 perseant int error;
392 1.24 perseant
393 1.71 yamt KASSERT(VOP_ISLOCKED(vp));
394 1.71 yamt KASSERT(vp2 == NULL || VOP_ISLOCKED(vp2));
395 1.71 yamt
396 1.40 perseant fs = VTOI(vp)->i_lfs;
397 1.44 perseant /*
398 1.44 perseant * We might need one directory block plus supporting indirect blocks,
399 1.44 perseant * plus an inode block and ifile page for the new vnode.
400 1.44 perseant */
401 1.71 yamt if ((error = lfs_reserve(fs, vp, vp2, NRESERVE(fs))) != 0)
402 1.44 perseant return (error);
403 1.70 yamt
404 1.40 perseant if (fs->lfs_dirops == 0)
405 1.40 perseant lfs_check(vp, LFS_UNUSED_LBN, 0);
406 1.84 perseant while (fs->lfs_writer || lfs_dirvcount > LFS_MAX_DIROP) {
407 1.59 chs if (fs->lfs_writer)
408 1.63 perseant tsleep(&fs->lfs_dirops, PRIBIO + 1, "lfs_sdirop", 0);
409 1.84 perseant if (lfs_dirvcount > LFS_MAX_DIROP && fs->lfs_dirops == 0) {
410 1.84 perseant wakeup(&lfs_writer_daemon);
411 1.84 perseant preempt(NULL);
412 1.33 perseant }
413 1.33 perseant
414 1.84 perseant if (lfs_dirvcount > LFS_MAX_DIROP) {
415 1.24 perseant #ifdef DEBUG_LFS
416 1.44 perseant printf("lfs_set_dirop: sleeping with dirops=%d, "
417 1.44 perseant "dirvcount=%d\n", fs->lfs_dirops,
418 1.44 perseant lfs_dirvcount);
419 1.24 perseant #endif
420 1.59 chs if ((error = tsleep(&lfs_dirvcount, PCATCH|PUSER,
421 1.59 chs "lfs_maxdirop", 0)) != 0) {
422 1.70 yamt goto unreserve;
423 1.44 perseant }
424 1.24 perseant }
425 1.24 perseant }
426 1.24 perseant ++fs->lfs_dirops;
427 1.24 perseant fs->lfs_doifile = 1;
428 1.24 perseant
429 1.46 perseant /* Hold a reference so SET_ENDOP will be happy */
430 1.78 yamt vref(vp);
431 1.78 yamt if (vp2)
432 1.78 yamt vref(vp2);
433 1.46 perseant
434 1.24 perseant return 0;
435 1.70 yamt
436 1.70 yamt unreserve:
437 1.71 yamt lfs_reserve(fs, vp, vp2, -NRESERVE(fs));
438 1.70 yamt return error;
439 1.1 mycroft }
440 1.1 mycroft
441 1.71 yamt #define SET_ENDOP(fs, vp, str) SET_ENDOP2((fs), (vp), NULL, (str))
442 1.71 yamt #define SET_ENDOP2(fs, vp, vp2, str) { \
443 1.1 mycroft --(fs)->lfs_dirops; \
444 1.22 perseant if (!(fs)->lfs_dirops) { \
445 1.40 perseant if ((fs)->lfs_nadirop) { \
446 1.67 provos panic("SET_ENDOP: %s: no dirops but nadirop=%d", \
447 1.40 perseant (str), (fs)->lfs_nadirop); \
448 1.40 perseant } \
449 1.1 mycroft wakeup(&(fs)->lfs_writer); \
450 1.26 perseant lfs_check((vp),LFS_UNUSED_LBN,0); \
451 1.22 perseant } \
452 1.71 yamt lfs_reserve((fs), vp, vp2, -NRESERVE(fs)); /* XXX */ \
453 1.78 yamt vrele(vp); \
454 1.78 yamt if (vp2) \
455 1.78 yamt vrele(vp2); \
456 1.1 mycroft }
457 1.1 mycroft
458 1.86 perseant #define MARK_VNODE(dvp) do { \
459 1.84 perseant struct inode *_ip = VTOI(dvp); \
460 1.84 perseant struct lfs *_fs = _ip->i_lfs; \
461 1.84 perseant \
462 1.86 perseant if (!((dvp)->v_flag & VDIROP)) { \
463 1.86 perseant (void)lfs_vref(dvp); \
464 1.31 perseant ++lfs_dirvcount; \
465 1.84 perseant TAILQ_INSERT_TAIL(&_fs->lfs_dchainhd, _ip, i_lfs_dchain); \
466 1.22 perseant } \
467 1.86 perseant (dvp)->v_flag |= VDIROP; \
468 1.84 perseant if (!(_ip->i_flag & IN_ADIROP)) { \
469 1.84 perseant ++_fs->lfs_nadirop; \
470 1.37 perseant } \
471 1.84 perseant _ip->i_flag |= IN_ADIROP; \
472 1.59 chs } while (0)
473 1.37 perseant
474 1.40 perseant #define UNMARK_VNODE(vp) lfs_unmark_vnode(vp)
475 1.40 perseant
476 1.51 perseant void lfs_unmark_vnode(struct vnode *vp)
477 1.40 perseant {
478 1.40 perseant struct inode *ip;
479 1.40 perseant
480 1.40 perseant ip = VTOI(vp);
481 1.40 perseant
482 1.40 perseant if (ip->i_flag & IN_ADIROP)
483 1.40 perseant --ip->i_lfs->lfs_nadirop;
484 1.40 perseant ip->i_flag &= ~IN_ADIROP;
485 1.40 perseant }
486 1.15 fvdl
487 1.1 mycroft int
488 1.51 perseant lfs_symlink(void *v)
489 1.10 christos {
490 1.1 mycroft struct vop_symlink_args /* {
491 1.1 mycroft struct vnode *a_dvp;
492 1.1 mycroft struct vnode **a_vpp;
493 1.1 mycroft struct componentname *a_cnp;
494 1.1 mycroft struct vattr *a_vap;
495 1.1 mycroft char *a_target;
496 1.10 christos } */ *ap = v;
497 1.37 perseant int error;
498 1.1 mycroft
499 1.40 perseant if ((error = SET_DIROP(ap->a_dvp)) != 0) {
500 1.34 perseant vput(ap->a_dvp);
501 1.37 perseant return error;
502 1.34 perseant }
503 1.1 mycroft MARK_VNODE(ap->a_dvp);
504 1.37 perseant error = ufs_symlink(ap);
505 1.37 perseant UNMARK_VNODE(ap->a_dvp);
506 1.40 perseant if (*(ap->a_vpp))
507 1.37 perseant UNMARK_VNODE(*(ap->a_vpp));
508 1.37 perseant SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"symlink");
509 1.37 perseant return (error);
510 1.1 mycroft }
511 1.1 mycroft
512 1.1 mycroft int
513 1.51 perseant lfs_mknod(void *v)
514 1.10 christos {
515 1.22 perseant struct vop_mknod_args /* {
516 1.1 mycroft struct vnode *a_dvp;
517 1.1 mycroft struct vnode **a_vpp;
518 1.1 mycroft struct componentname *a_cnp;
519 1.1 mycroft struct vattr *a_vap;
520 1.22 perseant } */ *ap = v;
521 1.86 perseant struct vattr *vap = ap->a_vap;
522 1.86 perseant struct vnode **vpp = ap->a_vpp;
523 1.86 perseant struct inode *ip;
524 1.86 perseant int error;
525 1.52 assar struct mount *mp;
526 1.52 assar ino_t ino;
527 1.1 mycroft
528 1.40 perseant if ((error = SET_DIROP(ap->a_dvp)) != 0) {
529 1.34 perseant vput(ap->a_dvp);
530 1.28 perseant return error;
531 1.34 perseant }
532 1.1 mycroft MARK_VNODE(ap->a_dvp);
533 1.28 perseant error = ufs_makeinode(MAKEIMODE(vap->va_type, vap->va_mode),
534 1.86 perseant ap->a_dvp, vpp, ap->a_cnp);
535 1.37 perseant UNMARK_VNODE(ap->a_dvp);
536 1.86 perseant if (*(ap->a_vpp))
537 1.86 perseant UNMARK_VNODE(*(ap->a_vpp));
538 1.28 perseant
539 1.28 perseant /* Either way we're done with the dirop at this point */
540 1.26 perseant SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"mknod");
541 1.28 perseant
542 1.86 perseant if (error)
543 1.28 perseant return (error);
544 1.28 perseant
545 1.86 perseant ip = VTOI(*vpp);
546 1.52 assar mp = (*vpp)->v_mount;
547 1.52 assar ino = ip->i_number;
548 1.86 perseant ip->i_flag |= IN_ACCESS | IN_CHANGE | IN_UPDATE;
549 1.86 perseant if (vap->va_rdev != VNOVAL) {
550 1.86 perseant /*
551 1.86 perseant * Want to be able to use this to make badblock
552 1.86 perseant * inodes, so don't truncate the dev number.
553 1.86 perseant */
554 1.28 perseant #if 0
555 1.86 perseant ip->i_ffs_rdev = ufs_rw32(vap->va_rdev,
556 1.86 perseant UFS_MPNEEDSWAP((*vpp)->v_mount));
557 1.28 perseant #else
558 1.86 perseant ip->i_ffs_rdev = vap->va_rdev;
559 1.28 perseant #endif
560 1.86 perseant }
561 1.28 perseant /*
562 1.28 perseant * Call fsync to write the vnode so that we don't have to deal with
563 1.28 perseant * flushing it when it's marked VDIROP|VXLOCK.
564 1.28 perseant *
565 1.28 perseant * XXX KS - If we can't flush we also can't call vgone(), so must
566 1.28 perseant * return. But, that leaves this vnode in limbo, also not good.
567 1.28 perseant * Can this ever happen (barring hardware failure)?
568 1.28 perseant */
569 1.80 thorpej if ((error = VOP_FSYNC(*vpp, NOCRED, FSYNC_WAIT, 0, 0,
570 1.80 thorpej curproc)) != 0) {
571 1.40 perseant printf("Couldn't fsync in mknod (ino %d)---what do I do?\n",
572 1.40 perseant VTOI(*vpp)->i_number);
573 1.28 perseant return (error);
574 1.40 perseant }
575 1.86 perseant /*
576 1.86 perseant * Remove vnode so that it will be reloaded by VFS_VGET and
577 1.86 perseant * checked to see if it is an alias of an existing entry in
578 1.86 perseant * the inode cache.
579 1.86 perseant */
580 1.28 perseant /* Used to be vput, but that causes us to call VOP_INACTIVE twice. */
581 1.40 perseant VOP_UNLOCK(*vpp, 0);
582 1.28 perseant lfs_vunref(*vpp);
583 1.86 perseant (*vpp)->v_type = VNON;
584 1.86 perseant vgone(*vpp);
585 1.52 assar error = VFS_VGET(mp, ino, vpp);
586 1.52 assar if (error != 0) {
587 1.52 assar *vpp = NULL;
588 1.52 assar return (error);
589 1.52 assar }
590 1.86 perseant return (0);
591 1.1 mycroft }
592 1.1 mycroft
593 1.1 mycroft int
594 1.51 perseant lfs_create(void *v)
595 1.10 christos {
596 1.22 perseant struct vop_create_args /* {
597 1.1 mycroft struct vnode *a_dvp;
598 1.1 mycroft struct vnode **a_vpp;
599 1.1 mycroft struct componentname *a_cnp;
600 1.1 mycroft struct vattr *a_vap;
601 1.10 christos } */ *ap = v;
602 1.37 perseant int error;
603 1.1 mycroft
604 1.59 chs if ((error = SET_DIROP(ap->a_dvp)) != 0) {
605 1.34 perseant vput(ap->a_dvp);
606 1.37 perseant return error;
607 1.34 perseant }
608 1.1 mycroft MARK_VNODE(ap->a_dvp);
609 1.37 perseant error = ufs_create(ap);
610 1.37 perseant UNMARK_VNODE(ap->a_dvp);
611 1.86 perseant if (*(ap->a_vpp))
612 1.86 perseant UNMARK_VNODE(*(ap->a_vpp));
613 1.26 perseant SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"create");
614 1.37 perseant return (error);
615 1.22 perseant }
616 1.22 perseant
617 1.22 perseant int
618 1.51 perseant lfs_mkdir(void *v)
619 1.10 christos {
620 1.22 perseant struct vop_mkdir_args /* {
621 1.1 mycroft struct vnode *a_dvp;
622 1.1 mycroft struct vnode **a_vpp;
623 1.1 mycroft struct componentname *a_cnp;
624 1.1 mycroft struct vattr *a_vap;
625 1.10 christos } */ *ap = v;
626 1.37 perseant int error;
627 1.1 mycroft
628 1.59 chs if ((error = SET_DIROP(ap->a_dvp)) != 0) {
629 1.34 perseant vput(ap->a_dvp);
630 1.37 perseant return error;
631 1.34 perseant }
632 1.1 mycroft MARK_VNODE(ap->a_dvp);
633 1.37 perseant error = ufs_mkdir(ap);
634 1.37 perseant UNMARK_VNODE(ap->a_dvp);
635 1.86 perseant if (*(ap->a_vpp))
636 1.86 perseant UNMARK_VNODE(*(ap->a_vpp));
637 1.26 perseant SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"mkdir");
638 1.37 perseant return (error);
639 1.1 mycroft }
640 1.1 mycroft
641 1.1 mycroft int
642 1.51 perseant lfs_remove(void *v)
643 1.10 christos {
644 1.22 perseant struct vop_remove_args /* {
645 1.1 mycroft struct vnode *a_dvp;
646 1.1 mycroft struct vnode *a_vp;
647 1.1 mycroft struct componentname *a_cnp;
648 1.10 christos } */ *ap = v;
649 1.34 perseant struct vnode *dvp, *vp;
650 1.37 perseant int error;
651 1.34 perseant
652 1.34 perseant dvp = ap->a_dvp;
653 1.34 perseant vp = ap->a_vp;
654 1.71 yamt if ((error = SET_DIROP2(dvp, vp)) != 0) {
655 1.34 perseant if (dvp == vp)
656 1.34 perseant vrele(vp);
657 1.34 perseant else
658 1.34 perseant vput(vp);
659 1.34 perseant vput(dvp);
660 1.37 perseant return error;
661 1.34 perseant }
662 1.34 perseant MARK_VNODE(dvp);
663 1.34 perseant MARK_VNODE(vp);
664 1.37 perseant error = ufs_remove(ap);
665 1.37 perseant UNMARK_VNODE(dvp);
666 1.37 perseant UNMARK_VNODE(vp);
667 1.40 perseant
668 1.71 yamt SET_ENDOP2(VTOI(dvp)->i_lfs, dvp, vp, "remove");
669 1.37 perseant return (error);
670 1.1 mycroft }
671 1.1 mycroft
672 1.1 mycroft int
673 1.51 perseant lfs_rmdir(void *v)
674 1.10 christos {
675 1.22 perseant struct vop_rmdir_args /* {
676 1.1 mycroft struct vnodeop_desc *a_desc;
677 1.1 mycroft struct vnode *a_dvp;
678 1.1 mycroft struct vnode *a_vp;
679 1.1 mycroft struct componentname *a_cnp;
680 1.10 christos } */ *ap = v;
681 1.84 perseant struct vnode *vp;
682 1.37 perseant int error;
683 1.1 mycroft
684 1.84 perseant vp = ap->a_vp;
685 1.71 yamt if ((error = SET_DIROP2(ap->a_dvp, ap->a_vp)) != 0) {
686 1.34 perseant vrele(ap->a_dvp);
687 1.69 yamt if (ap->a_vp != ap->a_dvp)
688 1.34 perseant VOP_UNLOCK(ap->a_dvp, 0);
689 1.84 perseant vput(vp);
690 1.37 perseant return error;
691 1.34 perseant }
692 1.1 mycroft MARK_VNODE(ap->a_dvp);
693 1.84 perseant MARK_VNODE(vp);
694 1.37 perseant error = ufs_rmdir(ap);
695 1.37 perseant UNMARK_VNODE(ap->a_dvp);
696 1.84 perseant UNMARK_VNODE(vp);
697 1.40 perseant
698 1.84 perseant SET_ENDOP2(VTOI(ap->a_dvp)->i_lfs, ap->a_dvp, vp, "rmdir");
699 1.37 perseant return (error);
700 1.1 mycroft }
701 1.1 mycroft
702 1.1 mycroft int
703 1.51 perseant lfs_link(void *v)
704 1.10 christos {
705 1.22 perseant struct vop_link_args /* {
706 1.9 mycroft struct vnode *a_dvp;
707 1.1 mycroft struct vnode *a_vp;
708 1.1 mycroft struct componentname *a_cnp;
709 1.10 christos } */ *ap = v;
710 1.37 perseant int error;
711 1.1 mycroft
712 1.40 perseant if ((error = SET_DIROP(ap->a_dvp)) != 0) {
713 1.34 perseant vput(ap->a_dvp);
714 1.37 perseant return error;
715 1.34 perseant }
716 1.9 mycroft MARK_VNODE(ap->a_dvp);
717 1.37 perseant error = ufs_link(ap);
718 1.37 perseant UNMARK_VNODE(ap->a_dvp);
719 1.26 perseant SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"link");
720 1.37 perseant return (error);
721 1.1 mycroft }
722 1.22 perseant
723 1.1 mycroft int
724 1.51 perseant lfs_rename(void *v)
725 1.10 christos {
726 1.22 perseant struct vop_rename_args /* {
727 1.1 mycroft struct vnode *a_fdvp;
728 1.1 mycroft struct vnode *a_fvp;
729 1.1 mycroft struct componentname *a_fcnp;
730 1.1 mycroft struct vnode *a_tdvp;
731 1.1 mycroft struct vnode *a_tvp;
732 1.1 mycroft struct componentname *a_tcnp;
733 1.10 christos } */ *ap = v;
734 1.30 perseant struct vnode *tvp, *fvp, *tdvp, *fdvp;
735 1.83 perseant struct componentname *tcnp, *fcnp;
736 1.30 perseant int error;
737 1.29 perseant struct lfs *fs;
738 1.29 perseant
739 1.29 perseant fs = VTOI(ap->a_fdvp)->i_lfs;
740 1.30 perseant tvp = ap->a_tvp;
741 1.30 perseant tdvp = ap->a_tdvp;
742 1.83 perseant tcnp = ap->a_tcnp;
743 1.30 perseant fvp = ap->a_fvp;
744 1.30 perseant fdvp = ap->a_fdvp;
745 1.83 perseant fcnp = ap->a_fcnp;
746 1.30 perseant
747 1.30 perseant /*
748 1.30 perseant * Check for cross-device rename.
749 1.30 perseant * If it is, we don't want to set dirops, just error out.
750 1.30 perseant * (In particular note that MARK_VNODE(tdvp) will DTWT on
751 1.30 perseant * a cross-device rename.)
752 1.30 perseant *
753 1.30 perseant * Copied from ufs_rename.
754 1.30 perseant */
755 1.30 perseant if ((fvp->v_mount != tdvp->v_mount) ||
756 1.30 perseant (tvp && (fvp->v_mount != tvp->v_mount))) {
757 1.30 perseant error = EXDEV;
758 1.34 perseant goto errout;
759 1.30 perseant }
760 1.83 perseant
761 1.83 perseant /*
762 1.83 perseant * Check to make sure we're not renaming a vnode onto itself
763 1.83 perseant * (deleting a hard link by renaming one name onto another);
764 1.83 perseant * if we are we can't recursively call VOP_REMOVE since that
765 1.83 perseant * would leave us with an unaccounted-for number of live dirops.
766 1.83 perseant *
767 1.83 perseant * Inline the relevant section of ufs_rename here, *before*
768 1.83 perseant * calling SET_DIROP2.
769 1.83 perseant */
770 1.83 perseant if (tvp && ((VTOI(tvp)->i_ffs_flags & (IMMUTABLE | APPEND)) ||
771 1.83 perseant (VTOI(tdvp)->i_ffs_flags & APPEND))) {
772 1.83 perseant error = EPERM;
773 1.83 perseant goto errout;
774 1.83 perseant }
775 1.86 perseant if (fvp == tvp) {
776 1.86 perseant if (fvp->v_type == VDIR) {
777 1.86 perseant error = EINVAL;
778 1.86 perseant goto errout;
779 1.86 perseant }
780 1.86 perseant
781 1.86 perseant /* Release destination completely. */
782 1.86 perseant VOP_ABORTOP(tdvp, tcnp);
783 1.86 perseant vput(tdvp);
784 1.86 perseant vput(tvp);
785 1.86 perseant
786 1.86 perseant /* Delete source. */
787 1.86 perseant vrele(fvp);
788 1.86 perseant fcnp->cn_flags &= ~(MODMASK | SAVESTART);
789 1.86 perseant fcnp->cn_flags |= LOCKPARENT | LOCKLEAF;
790 1.86 perseant fcnp->cn_nameiop = DELETE;
791 1.86 perseant if ((error = relookup(fdvp, &fvp, fcnp))){
792 1.86 perseant /* relookup blew away fdvp */
793 1.86 perseant return (error);
794 1.86 perseant }
795 1.86 perseant return (VOP_REMOVE(fdvp, fvp, fcnp));
796 1.86 perseant }
797 1.83 perseant
798 1.71 yamt if ((error = SET_DIROP2(tdvp, tvp)) != 0)
799 1.34 perseant goto errout;
800 1.30 perseant MARK_VNODE(fdvp);
801 1.30 perseant MARK_VNODE(tdvp);
802 1.71 yamt MARK_VNODE(fvp);
803 1.71 yamt if (tvp) {
804 1.71 yamt MARK_VNODE(tvp);
805 1.71 yamt }
806 1.83 perseant
807 1.30 perseant error = ufs_rename(ap);
808 1.37 perseant UNMARK_VNODE(fdvp);
809 1.37 perseant UNMARK_VNODE(tdvp);
810 1.71 yamt UNMARK_VNODE(fvp);
811 1.71 yamt if (tvp) {
812 1.71 yamt UNMARK_VNODE(tvp);
813 1.71 yamt }
814 1.71 yamt SET_ENDOP2(fs, tdvp, tvp, "rename");
815 1.34 perseant return (error);
816 1.34 perseant
817 1.34 perseant errout:
818 1.34 perseant VOP_ABORTOP(tdvp, ap->a_tcnp); /* XXX, why not in NFS? */
819 1.34 perseant if (tdvp == tvp)
820 1.34 perseant vrele(tdvp);
821 1.34 perseant else
822 1.34 perseant vput(tdvp);
823 1.34 perseant if (tvp)
824 1.34 perseant vput(tvp);
825 1.34 perseant VOP_ABORTOP(fdvp, ap->a_fcnp); /* XXX, why not in NFS? */
826 1.34 perseant vrele(fdvp);
827 1.34 perseant vrele(fvp);
828 1.30 perseant return (error);
829 1.1 mycroft }
830 1.22 perseant
831 1.1 mycroft /* XXX hack to avoid calling ITIMES in getattr */
832 1.1 mycroft int
833 1.51 perseant lfs_getattr(void *v)
834 1.10 christos {
835 1.1 mycroft struct vop_getattr_args /* {
836 1.1 mycroft struct vnode *a_vp;
837 1.1 mycroft struct vattr *a_vap;
838 1.1 mycroft struct ucred *a_cred;
839 1.1 mycroft struct proc *a_p;
840 1.10 christos } */ *ap = v;
841 1.35 augustss struct vnode *vp = ap->a_vp;
842 1.35 augustss struct inode *ip = VTOI(vp);
843 1.35 augustss struct vattr *vap = ap->a_vap;
844 1.51 perseant struct lfs *fs = ip->i_lfs;
845 1.1 mycroft /*
846 1.1 mycroft * Copy from inode table
847 1.1 mycroft */
848 1.1 mycroft vap->va_fsid = ip->i_dev;
849 1.1 mycroft vap->va_fileid = ip->i_number;
850 1.14 bouyer vap->va_mode = ip->i_ffs_mode & ~IFMT;
851 1.14 bouyer vap->va_nlink = ip->i_ffs_nlink;
852 1.14 bouyer vap->va_uid = ip->i_ffs_uid;
853 1.14 bouyer vap->va_gid = ip->i_ffs_gid;
854 1.14 bouyer vap->va_rdev = (dev_t)ip->i_ffs_rdev;
855 1.55 chs vap->va_size = vp->v_size;
856 1.14 bouyer vap->va_atime.tv_sec = ip->i_ffs_atime;
857 1.14 bouyer vap->va_atime.tv_nsec = ip->i_ffs_atimensec;
858 1.14 bouyer vap->va_mtime.tv_sec = ip->i_ffs_mtime;
859 1.14 bouyer vap->va_mtime.tv_nsec = ip->i_ffs_mtimensec;
860 1.14 bouyer vap->va_ctime.tv_sec = ip->i_ffs_ctime;
861 1.14 bouyer vap->va_ctime.tv_nsec = ip->i_ffs_ctimensec;
862 1.14 bouyer vap->va_flags = ip->i_ffs_flags;
863 1.14 bouyer vap->va_gen = ip->i_ffs_gen;
864 1.1 mycroft /* this doesn't belong here */
865 1.1 mycroft if (vp->v_type == VBLK)
866 1.1 mycroft vap->va_blocksize = BLKDEV_IOSIZE;
867 1.1 mycroft else if (vp->v_type == VCHR)
868 1.1 mycroft vap->va_blocksize = MAXBSIZE;
869 1.1 mycroft else
870 1.1 mycroft vap->va_blocksize = vp->v_mount->mnt_stat.f_iosize;
871 1.84 perseant vap->va_bytes = fsbtob(fs, (u_quad_t)ip->i_lfs_effnblks);
872 1.1 mycroft vap->va_type = vp->v_type;
873 1.1 mycroft vap->va_filerev = ip->i_modrev;
874 1.1 mycroft return (0);
875 1.61 perseant }
876 1.61 perseant
877 1.61 perseant /*
878 1.61 perseant * Check to make sure the inode blocks won't choke the buffer
879 1.61 perseant * cache, then call ufs_setattr as usual.
880 1.61 perseant */
881 1.61 perseant int
882 1.61 perseant lfs_setattr(void *v)
883 1.61 perseant {
884 1.61 perseant struct vop_getattr_args /* {
885 1.61 perseant struct vnode *a_vp;
886 1.61 perseant struct vattr *a_vap;
887 1.61 perseant struct ucred *a_cred;
888 1.61 perseant struct proc *a_p;
889 1.61 perseant } */ *ap = v;
890 1.61 perseant struct vnode *vp = ap->a_vp;
891 1.61 perseant
892 1.61 perseant lfs_check(vp, LFS_UNUSED_LBN, 0);
893 1.61 perseant return ufs_setattr(v);
894 1.1 mycroft }
895 1.22 perseant
896 1.1 mycroft /*
897 1.1 mycroft * Close called
898 1.1 mycroft *
899 1.1 mycroft * XXX -- we were using ufs_close, but since it updates the
900 1.1 mycroft * times on the inode, we might need to bump the uinodes
901 1.1 mycroft * count.
902 1.1 mycroft */
903 1.1 mycroft /* ARGSUSED */
904 1.1 mycroft int
905 1.51 perseant lfs_close(void *v)
906 1.10 christos {
907 1.1 mycroft struct vop_close_args /* {
908 1.1 mycroft struct vnode *a_vp;
909 1.1 mycroft int a_fflag;
910 1.1 mycroft struct ucred *a_cred;
911 1.1 mycroft struct proc *a_p;
912 1.10 christos } */ *ap = v;
913 1.35 augustss struct vnode *vp = ap->a_vp;
914 1.35 augustss struct inode *ip = VTOI(vp);
915 1.12 mycroft struct timespec ts;
916 1.1 mycroft
917 1.15 fvdl if (vp->v_usecount > 1) {
918 1.12 mycroft TIMEVAL_TO_TIMESPEC(&time, &ts);
919 1.22 perseant LFS_ITIMES(ip, &ts, &ts, &ts);
920 1.1 mycroft }
921 1.1 mycroft return (0);
922 1.65 perseant }
923 1.65 perseant
924 1.65 perseant /*
925 1.65 perseant * Close wrapper for special devices.
926 1.65 perseant *
927 1.65 perseant * Update the times on the inode then do device close.
928 1.65 perseant */
929 1.65 perseant int
930 1.65 perseant lfsspec_close(void *v)
931 1.65 perseant {
932 1.65 perseant struct vop_close_args /* {
933 1.65 perseant struct vnode *a_vp;
934 1.65 perseant int a_fflag;
935 1.65 perseant struct ucred *a_cred;
936 1.65 perseant struct proc *a_p;
937 1.65 perseant } */ *ap = v;
938 1.65 perseant struct vnode *vp;
939 1.65 perseant struct inode *ip;
940 1.65 perseant struct timespec ts;
941 1.65 perseant
942 1.65 perseant vp = ap->a_vp;
943 1.65 perseant ip = VTOI(vp);
944 1.65 perseant if (vp->v_usecount > 1) {
945 1.65 perseant TIMEVAL_TO_TIMESPEC(&time, &ts);
946 1.65 perseant LFS_ITIMES(ip, &ts, &ts, &ts);
947 1.65 perseant }
948 1.65 perseant return (VOCALL (spec_vnodeop_p, VOFFSET(vop_close), ap));
949 1.65 perseant }
950 1.65 perseant
951 1.65 perseant /*
952 1.65 perseant * Close wrapper for fifo's.
953 1.65 perseant *
954 1.65 perseant * Update the times on the inode then do device close.
955 1.65 perseant */
956 1.65 perseant int
957 1.65 perseant lfsfifo_close(void *v)
958 1.65 perseant {
959 1.65 perseant struct vop_close_args /* {
960 1.65 perseant struct vnode *a_vp;
961 1.65 perseant int a_fflag;
962 1.65 perseant struct ucred *a_cred;
963 1.65 perseant struct proc *a_p;
964 1.65 perseant } */ *ap = v;
965 1.65 perseant struct vnode *vp;
966 1.65 perseant struct inode *ip;
967 1.65 perseant struct timespec ts;
968 1.65 perseant
969 1.65 perseant vp = ap->a_vp;
970 1.65 perseant ip = VTOI(vp);
971 1.65 perseant if (ap->a_vp->v_usecount > 1) {
972 1.65 perseant TIMEVAL_TO_TIMESPEC(&time, &ts);
973 1.65 perseant LFS_ITIMES(ip, &ts, &ts, &ts);
974 1.65 perseant }
975 1.65 perseant return (VOCALL (fifo_vnodeop_p, VOFFSET(vop_close), ap));
976 1.1 mycroft }
977 1.1 mycroft
978 1.1 mycroft /*
979 1.15 fvdl * Reclaim an inode so that it can be used for other purposes.
980 1.1 mycroft */
981 1.1 mycroft int lfs_no_inactive = 0;
982 1.1 mycroft
983 1.1 mycroft int
984 1.51 perseant lfs_reclaim(void *v)
985 1.10 christos {
986 1.1 mycroft struct vop_reclaim_args /* {
987 1.1 mycroft struct vnode *a_vp;
988 1.15 fvdl struct proc *a_p;
989 1.10 christos } */ *ap = v;
990 1.15 fvdl struct vnode *vp = ap->a_vp;
991 1.84 perseant struct inode *ip = VTOI(vp);
992 1.1 mycroft int error;
993 1.77 yamt
994 1.84 perseant KASSERT(ip->i_ffs_nlink == ip->i_ffs_effnlink);
995 1.1 mycroft
996 1.84 perseant LFS_CLR_UINO(ip, IN_ALLMOD);
997 1.15 fvdl if ((error = ufs_reclaim(vp, ap->a_p)))
998 1.1 mycroft return (error);
999 1.84 perseant pool_put(&lfs_inoext_pool, ip->inode_ext.lfs);
1000 1.84 perseant ip->inode_ext.lfs = NULL;
1001 1.19 thorpej pool_put(&lfs_inode_pool, vp->v_data);
1002 1.1 mycroft vp->v_data = NULL;
1003 1.94 perseant return (0);
1004 1.94 perseant }
1005 1.94 perseant
1006 1.94 perseant /*
1007 1.94 perseant * Read a block from, or write a block to, a storage device.
1008 1.94 perseant * In order to avoid reading blocks that are in the process of being
1009 1.94 perseant * written by the cleaner---and hence are not mutexed by the normal
1010 1.94 perseant * buffer cache / page cache mechanisms---check for collisions before
1011 1.94 perseant * reading.
1012 1.94 perseant *
1013 1.94 perseant * We inline ufs_strategy to make sure that the VOP_BMAP occurs *before*
1014 1.94 perseant * the active cleaner test.
1015 1.94 perseant *
1016 1.94 perseant * XXX This code assumes that lfs_markv makes synchronous checkpoints.
1017 1.94 perseant */
1018 1.94 perseant int
1019 1.94 perseant lfs_strategy(void *v)
1020 1.94 perseant {
1021 1.94 perseant struct vop_strategy_args /* {
1022 1.94 perseant struct buf *a_bp;
1023 1.94 perseant } */ *ap = v;
1024 1.94 perseant struct buf *bp;
1025 1.94 perseant struct lfs *fs;
1026 1.94 perseant struct vnode *vp;
1027 1.94 perseant struct inode *ip;
1028 1.94 perseant daddr_t tbn;
1029 1.94 perseant int i, sn, error, slept;
1030 1.94 perseant
1031 1.94 perseant bp = ap->a_bp;
1032 1.94 perseant vp = bp->b_vp;
1033 1.94 perseant ip = VTOI(vp);
1034 1.94 perseant fs = ip->i_lfs;
1035 1.94 perseant
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.94 perseant while (slept && bp->b_flags & B_READ && 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.89 perseant fsidp = &ap->a_vp->v_mount->mnt_stat.f_fsid;
1227 1.89 perseant
1228 1.89 perseant switch(ap->a_command) {
1229 1.90 perseant case LFCNSEGWAITALL:
1230 1.89 perseant fsidp = NULL;
1231 1.89 perseant /* FALLSTHROUGH */
1232 1.90 perseant case LFCNSEGWAIT:
1233 1.89 perseant tvp = (struct timeval *)ap->a_data;
1234 1.90 perseant VOP_UNLOCK(ap->a_vp, 0);
1235 1.90 perseant error = lfs_segwait(fsidp, tvp);
1236 1.90 perseant VOP_LOCK(ap->a_vp, LK_EXCLUSIVE);
1237 1.90 perseant return error;
1238 1.89 perseant
1239 1.90 perseant case LFCNBMAPV:
1240 1.90 perseant case LFCNMARKV:
1241 1.89 perseant if ((error = suser(ap->a_p->p_ucred, &ap->a_p->p_acflag)) != 0)
1242 1.89 perseant return (error);
1243 1.90 perseant blkvp = *(struct lfs_fcntl_markv *)ap->a_data;
1244 1.89 perseant
1245 1.89 perseant blkcnt = blkvp.blkcnt;
1246 1.89 perseant if ((u_int) blkcnt > LFS_MARKV_MAXBLKCNT)
1247 1.89 perseant return (EINVAL);
1248 1.89 perseant blkiov = malloc(blkcnt * sizeof(BLOCK_INFO), M_SEGMENT, M_WAITOK);
1249 1.89 perseant if ((error = copyin(blkvp.blkiov, blkiov,
1250 1.89 perseant blkcnt * sizeof(BLOCK_INFO))) != 0) {
1251 1.89 perseant free(blkiov, M_SEGMENT);
1252 1.89 perseant return error;
1253 1.89 perseant }
1254 1.89 perseant
1255 1.90 perseant VOP_UNLOCK(ap->a_vp, 0);
1256 1.90 perseant if (ap->a_command == LFCNBMAPV)
1257 1.89 perseant error = lfs_bmapv(ap->a_p, fsidp, blkiov, blkcnt);
1258 1.90 perseant else /* LFCNMARKV */
1259 1.89 perseant error = lfs_markv(ap->a_p, fsidp, blkiov, blkcnt);
1260 1.89 perseant if (error == 0)
1261 1.89 perseant error = copyout(blkiov, blkvp.blkiov,
1262 1.89 perseant blkcnt * sizeof(BLOCK_INFO));
1263 1.90 perseant VOP_LOCK(ap->a_vp, LK_EXCLUSIVE);
1264 1.89 perseant free(blkiov, M_SEGMENT);
1265 1.89 perseant return error;
1266 1.92 perseant
1267 1.92 perseant case LFCNRECLAIM:
1268 1.92 perseant /*
1269 1.92 perseant * Flush dirops and write Ifile, allowing empty segments
1270 1.92 perseant * to be immediately reclaimed.
1271 1.92 perseant */
1272 1.92 perseant fs = VTOI(ap->a_vp)->i_lfs;
1273 1.92 perseant off = fs->lfs_offset;
1274 1.92 perseant lfs_seglock(fs, SEGM_FORCE_CKP | SEGM_CKP);
1275 1.92 perseant lfs_flush_dirops(fs);
1276 1.92 perseant LFS_CLEANERINFO(cip, fs, bp);
1277 1.92 perseant oclean = cip->clean;
1278 1.92 perseant LFS_SYNC_CLEANERINFO(cip, fs, bp, 1);
1279 1.92 perseant lfs_segwrite(ap->a_vp->v_mount, SEGM_FORCE_CKP);
1280 1.92 perseant lfs_segunlock(fs);
1281 1.92 perseant
1282 1.92 perseant #ifdef DEBUG_LFS
1283 1.92 perseant LFS_CLEANERINFO(cip, fs, bp);
1284 1.92 perseant oclean = cip->clean;
1285 1.92 perseant printf("lfs_fcntl: reclaim wrote %" PRId64 " blocks, cleaned "
1286 1.92 perseant "%" PRId32 " segments (activesb %d)\n",
1287 1.92 perseant fs->lfs_offset - off, cip->clean - oclean,
1288 1.92 perseant fs->lfs_activesb);
1289 1.92 perseant LFS_SYNC_CLEANERINFO(cip, fs, bp, 0);
1290 1.92 perseant #endif
1291 1.92 perseant
1292 1.92 perseant return 0;
1293 1.89 perseant
1294 1.89 perseant default:
1295 1.90 perseant return ufs_fcntl(v);
1296 1.89 perseant }
1297 1.89 perseant return 0;
1298 1.60 chs }
1299 1.60 chs
1300 1.60 chs int
1301 1.60 chs lfs_getpages(void *v)
1302 1.60 chs {
1303 1.60 chs struct vop_getpages_args /* {
1304 1.60 chs struct vnode *a_vp;
1305 1.60 chs voff_t a_offset;
1306 1.60 chs struct vm_page **a_m;
1307 1.60 chs int *a_count;
1308 1.60 chs int a_centeridx;
1309 1.60 chs vm_prot_t a_access_type;
1310 1.60 chs int a_advice;
1311 1.60 chs int a_flags;
1312 1.60 chs } */ *ap = v;
1313 1.60 chs
1314 1.60 chs if ((ap->a_access_type & VM_PROT_WRITE) != 0) {
1315 1.60 chs LFS_SET_UINO(VTOI(ap->a_vp), IN_MODIFIED);
1316 1.60 chs }
1317 1.95 perseant return genfs_getpages(v);
1318 1.1 mycroft }
1319 1.84 perseant
1320 1.84 perseant /*
1321 1.84 perseant * Make sure that for all pages in every block in the given range,
1322 1.84 perseant * either all are dirty or all are clean. If any of the pages
1323 1.84 perseant * we've seen so far are dirty, put the vnode on the paging chain,
1324 1.84 perseant * and mark it IN_PAGING.
1325 1.84 perseant */
1326 1.84 perseant static int
1327 1.84 perseant check_dirty(struct lfs *fs, struct vnode *vp,
1328 1.84 perseant off_t startoffset, off_t endoffset, off_t blkeof,
1329 1.84 perseant int flags)
1330 1.84 perseant {
1331 1.86 perseant int by_list;
1332 1.84 perseant struct vm_page *curpg, *pgs[MAXBSIZE / PAGE_SIZE], *pg;
1333 1.84 perseant struct lwp *l = curlwp ? curlwp : &lwp0;
1334 1.84 perseant off_t soff;
1335 1.84 perseant voff_t off;
1336 1.84 perseant int i, dirty, tdirty, nonexistent, any_dirty;
1337 1.84 perseant int pages_per_block = fs->lfs_bsize >> PAGE_SHIFT;
1338 1.84 perseant
1339 1.84 perseant top:
1340 1.84 perseant by_list = (vp->v_uobj.uo_npages <=
1341 1.84 perseant ((endoffset - startoffset) >> PAGE_SHIFT) *
1342 1.84 perseant UVM_PAGE_HASH_PENALTY);
1343 1.84 perseant any_dirty = 0;
1344 1.84 perseant
1345 1.84 perseant if (by_list) {
1346 1.84 perseant curpg = TAILQ_FIRST(&vp->v_uobj.memq);
1347 1.84 perseant PHOLD(l);
1348 1.84 perseant } else {
1349 1.84 perseant soff = startoffset;
1350 1.84 perseant }
1351 1.84 perseant while (by_list || soff < MIN(blkeof, endoffset)) {
1352 1.84 perseant if (by_list) {
1353 1.84 perseant if (pages_per_block > 1) {
1354 1.84 perseant while (curpg && (curpg->offset & fs->lfs_bmask))
1355 1.84 perseant curpg = TAILQ_NEXT(curpg, listq);
1356 1.84 perseant }
1357 1.84 perseant if (curpg == NULL)
1358 1.84 perseant break;
1359 1.84 perseant soff = curpg->offset;
1360 1.84 perseant }
1361 1.84 perseant
1362 1.84 perseant /*
1363 1.84 perseant * Mark all pages in extended range busy; find out if any
1364 1.84 perseant * of them are dirty.
1365 1.84 perseant */
1366 1.84 perseant nonexistent = dirty = 0;
1367 1.84 perseant for (i = 0; i == 0 || i < pages_per_block; i++) {
1368 1.84 perseant if (by_list && pages_per_block <= 1) {
1369 1.84 perseant pgs[i] = pg = curpg;
1370 1.84 perseant } else {
1371 1.84 perseant off = soff + (i << PAGE_SHIFT);
1372 1.84 perseant pgs[i] = pg = uvm_pagelookup(&vp->v_uobj, off);
1373 1.84 perseant if (pg == NULL) {
1374 1.84 perseant ++nonexistent;
1375 1.84 perseant continue;
1376 1.84 perseant }
1377 1.84 perseant }
1378 1.84 perseant KASSERT(pg != NULL);
1379 1.84 perseant while (pg->flags & PG_BUSY) {
1380 1.84 perseant pg->flags |= PG_WANTED;
1381 1.84 perseant UVM_UNLOCK_AND_WAIT(pg, &vp->v_interlock, 0,
1382 1.84 perseant "lfsput", 0);
1383 1.84 perseant simple_lock(&vp->v_interlock);
1384 1.96 perseant if (by_list) {
1385 1.96 perseant if (i > 0)
1386 1.96 perseant uvm_page_unbusy(pgs, i);
1387 1.84 perseant goto top;
1388 1.96 perseant }
1389 1.84 perseant }
1390 1.84 perseant pg->flags |= PG_BUSY;
1391 1.84 perseant UVM_PAGE_OWN(pg, "lfs_putpages");
1392 1.84 perseant
1393 1.84 perseant pmap_page_protect(pg, VM_PROT_NONE);
1394 1.84 perseant tdirty = (pmap_clear_modify(pg) ||
1395 1.84 perseant (pg->flags & PG_CLEAN) == 0);
1396 1.84 perseant dirty += tdirty;
1397 1.84 perseant }
1398 1.84 perseant if (pages_per_block > 0 && nonexistent >= pages_per_block) {
1399 1.84 perseant if (by_list) {
1400 1.84 perseant curpg = TAILQ_NEXT(curpg, listq);
1401 1.84 perseant } else {
1402 1.84 perseant soff += fs->lfs_bsize;
1403 1.84 perseant }
1404 1.84 perseant continue;
1405 1.84 perseant }
1406 1.84 perseant
1407 1.84 perseant any_dirty += dirty;
1408 1.84 perseant KASSERT(nonexistent == 0);
1409 1.84 perseant
1410 1.84 perseant /*
1411 1.84 perseant * If any are dirty make all dirty; unbusy them,
1412 1.88 perseant * but if we were asked to clean, wire them so that
1413 1.88 perseant * the pagedaemon doesn't bother us about them while
1414 1.88 perseant * they're on their way to disk.
1415 1.84 perseant */
1416 1.84 perseant for (i = 0; i == 0 || i < pages_per_block; i++) {
1417 1.84 perseant pg = pgs[i];
1418 1.84 perseant KASSERT(!((pg->flags & PG_CLEAN) && (pg->flags & PG_DELWRI)));
1419 1.84 perseant if (dirty) {
1420 1.84 perseant pg->flags &= ~PG_CLEAN;
1421 1.84 perseant if (flags & PGO_FREE) {
1422 1.84 perseant /* XXXUBC need better way to update */
1423 1.96 perseant simple_lock(&lfs_subsys_lock);
1424 1.84 perseant lfs_subsys_pages += MIN(1, pages_per_block);
1425 1.96 perseant simple_unlock(&lfs_subsys_lock);
1426 1.85 yamt /*
1427 1.96 perseant * Wire the page so that
1428 1.96 perseant * pdaemon doesn't see it again.
1429 1.85 yamt */
1430 1.84 perseant uvm_lock_pageq();
1431 1.85 yamt uvm_pagewire(pg);
1432 1.85 yamt uvm_unlock_pageq();
1433 1.88 perseant
1434 1.84 perseant /* Suspended write flag */
1435 1.84 perseant pg->flags |= PG_DELWRI;
1436 1.84 perseant }
1437 1.84 perseant }
1438 1.84 perseant if (pg->flags & PG_WANTED)
1439 1.84 perseant wakeup(pg);
1440 1.84 perseant pg->flags &= ~(PG_WANTED|PG_BUSY);
1441 1.85 yamt UVM_PAGE_OWN(pg, NULL);
1442 1.84 perseant }
1443 1.84 perseant
1444 1.84 perseant if (by_list) {
1445 1.84 perseant curpg = TAILQ_NEXT(curpg, listq);
1446 1.84 perseant } else {
1447 1.84 perseant soff += MAX(PAGE_SIZE, fs->lfs_bsize);
1448 1.84 perseant }
1449 1.84 perseant }
1450 1.84 perseant if (by_list) {
1451 1.84 perseant PRELE(l);
1452 1.84 perseant }
1453 1.84 perseant
1454 1.84 perseant /*
1455 1.84 perseant * If any pages were dirty, mark this inode as "pageout requested",
1456 1.84 perseant * and put it on the paging queue.
1457 1.84 perseant * XXXUBC locking (check locking on dchainhd too)
1458 1.84 perseant */
1459 1.84 perseant #ifdef notyet
1460 1.84 perseant if (any_dirty) {
1461 1.84 perseant if (!(ip->i_flags & IN_PAGING)) {
1462 1.84 perseant ip->i_flags |= IN_PAGING;
1463 1.84 perseant TAILQ_INSERT_TAIL(&fs->lfs_pchainhd, ip, i_lfs_pchain);
1464 1.84 perseant }
1465 1.84 perseant }
1466 1.84 perseant #endif
1467 1.84 perseant return any_dirty;
1468 1.84 perseant }
1469 1.84 perseant
1470 1.84 perseant /*
1471 1.84 perseant * lfs_putpages functions like genfs_putpages except that
1472 1.84 perseant *
1473 1.84 perseant * (1) It needs to bounds-check the incoming requests to ensure that
1474 1.84 perseant * they are block-aligned; if they are not, expand the range and
1475 1.84 perseant * do the right thing in case, e.g., the requested range is clean
1476 1.84 perseant * but the expanded range is dirty.
1477 1.84 perseant * (2) It needs to explicitly send blocks to be written when it is done.
1478 1.84 perseant * VOP_PUTPAGES is not ever called with the seglock held, so
1479 1.84 perseant * we simply take the seglock and let lfs_segunlock wait for us.
1480 1.84 perseant * XXX Actually we can be called with the seglock held, if we have
1481 1.84 perseant * XXX to flush a vnode while lfs_markv is in operation. As of this
1482 1.84 perseant * XXX writing we panic in this case.
1483 1.84 perseant *
1484 1.84 perseant * Assumptions:
1485 1.84 perseant *
1486 1.84 perseant * (1) The caller does not hold any pages in this vnode busy. If it does,
1487 1.84 perseant * there is a danger that when we expand the page range and busy the
1488 1.84 perseant * pages we will deadlock.
1489 1.84 perseant * (2) We are called with vp->v_interlock held; we must return with it
1490 1.84 perseant * released.
1491 1.84 perseant * (3) We don't absolutely have to free pages right away, provided that
1492 1.84 perseant * the request does not have PGO_SYNCIO. When the pagedaemon gives
1493 1.84 perseant * us a request with PGO_FREE, we take the pages out of the paging
1494 1.84 perseant * queue and wake up the writer, which will handle freeing them for us.
1495 1.84 perseant *
1496 1.84 perseant * We ensure that for any filesystem block, all pages for that
1497 1.84 perseant * block are either resident or not, even if those pages are higher
1498 1.84 perseant * than EOF; that means that we will be getting requests to free
1499 1.84 perseant * "unused" pages above EOF all the time, and should ignore them.
1500 1.84 perseant */
1501 1.84 perseant
1502 1.84 perseant int
1503 1.84 perseant lfs_putpages(void *v)
1504 1.84 perseant {
1505 1.84 perseant int error;
1506 1.84 perseant struct vop_putpages_args /* {
1507 1.84 perseant struct vnode *a_vp;
1508 1.84 perseant voff_t a_offlo;
1509 1.84 perseant voff_t a_offhi;
1510 1.84 perseant int a_flags;
1511 1.84 perseant } */ *ap = v;
1512 1.84 perseant struct vnode *vp;
1513 1.84 perseant struct inode *ip;
1514 1.84 perseant struct lfs *fs;
1515 1.84 perseant struct segment *sp;
1516 1.84 perseant off_t origoffset, startoffset, endoffset, origendoffset, blkeof;
1517 1.95 perseant off_t off, max_endoffset;
1518 1.84 perseant int pages_per_block;
1519 1.84 perseant int s, sync, dirty, pagedaemon;
1520 1.95 perseant struct vm_page *pg;
1521 1.84 perseant UVMHIST_FUNC("lfs_putpages"); UVMHIST_CALLED(ubchist);
1522 1.84 perseant
1523 1.84 perseant vp = ap->a_vp;
1524 1.84 perseant ip = VTOI(vp);
1525 1.84 perseant fs = ip->i_lfs;
1526 1.84 perseant sync = (ap->a_flags & PGO_SYNCIO);
1527 1.84 perseant pagedaemon = (curproc == uvm.pagedaemon_proc);
1528 1.84 perseant
1529 1.84 perseant /* Putpages does nothing for metadata. */
1530 1.84 perseant if (vp == fs->lfs_ivnode || vp->v_type != VREG) {
1531 1.84 perseant simple_unlock(&vp->v_interlock);
1532 1.84 perseant return 0;
1533 1.84 perseant }
1534 1.84 perseant
1535 1.84 perseant /*
1536 1.84 perseant * If there are no pages, don't do anything.
1537 1.84 perseant */
1538 1.84 perseant if (vp->v_uobj.uo_npages == 0) {
1539 1.84 perseant s = splbio();
1540 1.84 perseant if (LIST_FIRST(&vp->v_dirtyblkhd) == NULL &&
1541 1.84 perseant (vp->v_flag & VONWORKLST)) {
1542 1.84 perseant vp->v_flag &= ~VONWORKLST;
1543 1.84 perseant LIST_REMOVE(vp, v_synclist);
1544 1.84 perseant }
1545 1.84 perseant splx(s);
1546 1.84 perseant simple_unlock(&vp->v_interlock);
1547 1.84 perseant return 0;
1548 1.84 perseant }
1549 1.84 perseant
1550 1.84 perseant blkeof = blkroundup(fs, ip->i_ffs_size);
1551 1.84 perseant
1552 1.84 perseant /*
1553 1.84 perseant * Ignore requests to free pages past EOF but in the same block
1554 1.84 perseant * as EOF, unless the request is synchronous. (XXX why sync?)
1555 1.84 perseant * XXXUBC Make these pages look "active" so the pagedaemon won't
1556 1.84 perseant * XXXUBC bother us with them again.
1557 1.84 perseant */
1558 1.84 perseant if (!sync && ap->a_offlo >= ip->i_ffs_size && ap->a_offlo < blkeof) {
1559 1.84 perseant origoffset = ap->a_offlo;
1560 1.95 perseant for (off = origoffset; off < blkeof; off += fs->lfs_bsize) {
1561 1.95 perseant pg = uvm_pagelookup(&vp->v_uobj, off);
1562 1.95 perseant KASSERT(pg != NULL);
1563 1.95 perseant while (pg->flags & PG_BUSY) {
1564 1.95 perseant pg->flags |= PG_WANTED;
1565 1.95 perseant UVM_UNLOCK_AND_WAIT(pg, &vp->v_interlock, 0,
1566 1.95 perseant "lfsput2", 0);
1567 1.95 perseant simple_lock(&vp->v_interlock);
1568 1.95 perseant }
1569 1.95 perseant uvm_lock_pageq();
1570 1.95 perseant uvm_pageactivate(pg);
1571 1.95 perseant uvm_unlock_pageq();
1572 1.95 perseant }
1573 1.84 perseant ap->a_offlo = blkeof;
1574 1.84 perseant if (ap->a_offhi > 0 && ap->a_offhi <= ap->a_offlo) {
1575 1.84 perseant simple_unlock(&vp->v_interlock);
1576 1.84 perseant return 0;
1577 1.84 perseant }
1578 1.84 perseant }
1579 1.84 perseant
1580 1.84 perseant /*
1581 1.84 perseant * Extend page range to start and end at block boundaries.
1582 1.84 perseant * (For the purposes of VOP_PUTPAGES, fragments don't exist.)
1583 1.84 perseant */
1584 1.84 perseant pages_per_block = fs->lfs_bsize >> PAGE_SHIFT;
1585 1.86 perseant origoffset = ap->a_offlo;
1586 1.84 perseant origendoffset = ap->a_offhi;
1587 1.86 perseant startoffset = origoffset & ~(fs->lfs_bmask);
1588 1.84 perseant max_endoffset = (trunc_page(LLONG_MAX) >> fs->lfs_bshift)
1589 1.84 perseant << fs->lfs_bshift;
1590 1.84 perseant
1591 1.84 perseant if (origendoffset == 0 || ap->a_flags & PGO_ALLPAGES) {
1592 1.86 perseant endoffset = max_endoffset;
1593 1.84 perseant origendoffset = endoffset;
1594 1.86 perseant } else {
1595 1.84 perseant origendoffset = round_page(ap->a_offhi);
1596 1.84 perseant endoffset = round_page(blkroundup(fs, origendoffset));
1597 1.84 perseant }
1598 1.84 perseant
1599 1.84 perseant KASSERT(startoffset > 0 || endoffset >= startoffset);
1600 1.84 perseant if (startoffset == endoffset) {
1601 1.84 perseant /* Nothing to do, why were we called? */
1602 1.84 perseant simple_unlock(&vp->v_interlock);
1603 1.84 perseant #ifdef DEBUG
1604 1.84 perseant printf("lfs_putpages: startoffset = endoffset = %" PRId64 "\n",
1605 1.84 perseant startoffset);
1606 1.84 perseant #endif
1607 1.84 perseant return 0;
1608 1.84 perseant }
1609 1.84 perseant
1610 1.84 perseant ap->a_offlo = startoffset;
1611 1.84 perseant ap->a_offhi = endoffset;
1612 1.84 perseant
1613 1.84 perseant if (!(ap->a_flags & PGO_CLEANIT))
1614 1.84 perseant return genfs_putpages(v);
1615 1.84 perseant
1616 1.84 perseant /*
1617 1.84 perseant * Make sure that all pages in any given block are dirty, or
1618 1.84 perseant * none of them are. Find out if any of the pages we've been
1619 1.84 perseant * asked about are dirty. If none are dirty, send them on
1620 1.84 perseant * through genfs_putpages(), albeit with adjusted offsets.
1621 1.84 perseant * XXXUBC I am assuming here that they can't be dirtied in
1622 1.84 perseant * XXXUBC the meantime, but I bet that's wrong.
1623 1.84 perseant */
1624 1.84 perseant dirty = check_dirty(fs, vp, startoffset, endoffset, blkeof, ap->a_flags);
1625 1.84 perseant if (!dirty)
1626 1.84 perseant return genfs_putpages(v);
1627 1.84 perseant
1628 1.84 perseant /*
1629 1.84 perseant * Dirty and asked to clean.
1630 1.84 perseant *
1631 1.84 perseant * Pagedaemon can't actually write LFS pages; wake up
1632 1.84 perseant * the writer to take care of that. The writer will
1633 1.84 perseant * notice the pager inode queue and act on that.
1634 1.84 perseant */
1635 1.84 perseant if (pagedaemon) {
1636 1.84 perseant ++fs->lfs_pdflush;
1637 1.84 perseant wakeup(&lfs_writer_daemon);
1638 1.87 yamt simple_unlock(&vp->v_interlock);
1639 1.84 perseant return EWOULDBLOCK;
1640 1.84 perseant }
1641 1.84 perseant
1642 1.84 perseant /*
1643 1.84 perseant * If this is a file created in a recent dirop, we can't flush its
1644 1.84 perseant * inode until the dirop is complete. Drain dirops, then flush the
1645 1.84 perseant * filesystem (taking care of any other pending dirops while we're
1646 1.84 perseant * at it).
1647 1.84 perseant */
1648 1.84 perseant if ((ap->a_flags & (PGO_CLEANIT|PGO_LOCKED)) == PGO_CLEANIT &&
1649 1.84 perseant (vp->v_flag & VDIROP)) {
1650 1.84 perseant int locked;
1651 1.84 perseant
1652 1.84 perseant /* printf("putpages to clean VDIROP, flushing\n"); */
1653 1.84 perseant while (fs->lfs_dirops > 0) {
1654 1.84 perseant ++fs->lfs_diropwait;
1655 1.84 perseant tsleep(&fs->lfs_writer, PRIBIO+1, "ppdirop", 0);
1656 1.84 perseant --fs->lfs_diropwait;
1657 1.84 perseant }
1658 1.84 perseant ++fs->lfs_writer;
1659 1.84 perseant locked = VOP_ISLOCKED(vp) && /* XXX */
1660 1.84 perseant vp->v_lock.lk_lockholder == curproc->p_pid;
1661 1.84 perseant if (locked)
1662 1.84 perseant VOP_UNLOCK(vp, 0);
1663 1.84 perseant simple_unlock(&vp->v_interlock);
1664 1.84 perseant
1665 1.84 perseant lfs_flush_fs(fs, sync ? SEGM_SYNC : 0);
1666 1.84 perseant
1667 1.84 perseant simple_lock(&vp->v_interlock);
1668 1.84 perseant if (locked)
1669 1.84 perseant VOP_LOCK(vp, LK_EXCLUSIVE);
1670 1.84 perseant if (--fs->lfs_writer == 0)
1671 1.84 perseant wakeup(&fs->lfs_dirops);
1672 1.84 perseant
1673 1.84 perseant /* XXX the flush should have taken care of this one too! */
1674 1.84 perseant }
1675 1.84 perseant
1676 1.84 perseant
1677 1.84 perseant /*
1678 1.86 perseant * This is it. We are going to write some pages. From here on
1679 1.84 perseant * down it's all just mechanics.
1680 1.84 perseant *
1681 1.84 perseant * If there are more than one page per block, we don't want to get
1682 1.84 perseant * caught locking them backwards; so set PGO_BUSYFAIL to avoid
1683 1.84 perseant * deadlocks. Also, don't let genfs_putpages wait;
1684 1.84 perseant * lfs_segunlock will wait for us, if need be.
1685 1.84 perseant */
1686 1.84 perseant ap->a_flags &= ~PGO_SYNCIO;
1687 1.84 perseant if (pages_per_block > 1)
1688 1.84 perseant ap->a_flags |= PGO_BUSYFAIL;
1689 1.84 perseant
1690 1.84 perseant /*
1691 1.84 perseant * If we've already got the seglock, flush the node and return.
1692 1.84 perseant * The FIP has already been set up for us by lfs_writefile,
1693 1.84 perseant * and FIP cleanup and lfs_updatemeta will also be done there,
1694 1.84 perseant * unless genfs_putpages returns EDEADLK; then we must flush
1695 1.84 perseant * what we have, and correct FIP and segment header accounting.
1696 1.84 perseant */
1697 1.84 perseant if (ap->a_flags & PGO_LOCKED) {
1698 1.84 perseant sp = fs->lfs_sp;
1699 1.84 perseant sp->vp = vp;
1700 1.84 perseant
1701 1.84 perseant while ((error = genfs_putpages(v)) == EDEADLK) {
1702 1.84 perseant #ifdef DEBUG_LFS
1703 1.84 perseant printf("lfs_putpages: genfs_putpages returned EDEADLK"
1704 1.84 perseant " ino %d off %x (seg %d)\n",
1705 1.84 perseant ip->i_number, fs->lfs_offset,
1706 1.84 perseant dtosn(fs, fs->lfs_offset));
1707 1.84 perseant #endif
1708 1.88 perseant /* If nothing to write, short-circuit */
1709 1.88 perseant if (sp->cbpp - sp->bpp == 1) {
1710 1.88 perseant preempt(NULL);
1711 1.88 perseant simple_lock(&vp->v_interlock);
1712 1.88 perseant continue;
1713 1.88 perseant }
1714 1.84 perseant /* Write gathered pages */
1715 1.86 perseant lfs_updatemeta(sp);
1716 1.86 perseant (void) lfs_writeseg(fs, sp);
1717 1.84 perseant
1718 1.84 perseant /* Reinitialize brand new FIP and add us to it */
1719 1.84 perseant sp->vp = vp;
1720 1.86 perseant sp->fip->fi_version = ip->i_ffs_gen;
1721 1.86 perseant sp->fip->fi_ino = ip->i_number;
1722 1.86 perseant /* Add us to the new segment summary. */
1723 1.86 perseant ++((SEGSUM *)(sp->segsum))->ss_nfinfo;
1724 1.86 perseant sp->sum_bytes_left -=
1725 1.86 perseant sizeof(struct finfo) - sizeof(int32_t);
1726 1.84 perseant
1727 1.84 perseant /* Give the write a chance to complete */
1728 1.84 perseant preempt(NULL);
1729 1.84 perseant simple_lock(&vp->v_interlock);
1730 1.84 perseant }
1731 1.84 perseant return error;
1732 1.84 perseant }
1733 1.84 perseant
1734 1.87 yamt simple_unlock(&vp->v_interlock);
1735 1.84 perseant /*
1736 1.84 perseant * Take the seglock, because we are going to be writing pages.
1737 1.84 perseant */
1738 1.84 perseant if ((error = lfs_seglock(fs, SEGM_PROT | (sync ? SEGM_SYNC : 0))) != 0)
1739 1.84 perseant return error;
1740 1.84 perseant
1741 1.84 perseant /*
1742 1.84 perseant * VOP_PUTPAGES should not be called while holding the seglock.
1743 1.93 perseant * XXXUBC fix lfs_markv, or do this properly.
1744 1.84 perseant */
1745 1.93 perseant /* KASSERT(fs->lfs_seglock == 1); */
1746 1.84 perseant
1747 1.84 perseant /*
1748 1.84 perseant * We assume we're being called with sp->fip pointing at blank space.
1749 1.84 perseant * Account for a new FIP in the segment header, and set sp->vp.
1750 1.84 perseant * (This should duplicate the setup at the top of lfs_writefile().)
1751 1.84 perseant */
1752 1.84 perseant sp = fs->lfs_sp;
1753 1.86 perseant if (sp->seg_bytes_left < fs->lfs_bsize ||
1754 1.86 perseant sp->sum_bytes_left < sizeof(struct finfo))
1755 1.86 perseant (void) lfs_writeseg(fs, fs->lfs_sp);
1756 1.84 perseant
1757 1.86 perseant sp->sum_bytes_left -= sizeof(struct finfo) - sizeof(int32_t);
1758 1.86 perseant ++((SEGSUM *)(sp->segsum))->ss_nfinfo;
1759 1.84 perseant sp->vp = vp;
1760 1.84 perseant
1761 1.86 perseant if (vp->v_flag & VDIROP)
1762 1.86 perseant ((SEGSUM *)(sp->segsum))->ss_flags |= (SS_DIROP|SS_CONT);
1763 1.84 perseant
1764 1.86 perseant sp->fip->fi_nblocks = 0;
1765 1.86 perseant sp->fip->fi_ino = ip->i_number;
1766 1.84 perseant sp->fip->fi_version = ip->i_ffs_gen;
1767 1.84 perseant
1768 1.84 perseant /*
1769 1.84 perseant * Loop through genfs_putpages until all pages are gathered.
1770 1.88 perseant * genfs_putpages() drops the interlock, so reacquire it if necessary.
1771 1.84 perseant */
1772 1.87 yamt simple_lock(&vp->v_interlock);
1773 1.84 perseant while ((error = genfs_putpages(v)) == EDEADLK) {
1774 1.84 perseant #ifdef DEBUG_LFS
1775 1.84 perseant printf("lfs_putpages: genfs_putpages returned EDEADLK [2]"
1776 1.84 perseant " ino %d off %x (seg %d)\n",
1777 1.84 perseant ip->i_number, fs->lfs_offset,
1778 1.84 perseant dtosn(fs, fs->lfs_offset));
1779 1.84 perseant #endif
1780 1.88 perseant /* If nothing to write, short-circuit */
1781 1.88 perseant if (sp->cbpp - sp->bpp == 1) {
1782 1.88 perseant preempt(NULL);
1783 1.88 perseant simple_lock(&vp->v_interlock);
1784 1.88 perseant continue;
1785 1.88 perseant }
1786 1.84 perseant /* Write gathered pages */
1787 1.86 perseant lfs_updatemeta(sp);
1788 1.86 perseant (void) lfs_writeseg(fs, sp);
1789 1.84 perseant
1790 1.84 perseant /*
1791 1.84 perseant * Reinitialize brand new FIP and add us to it.
1792 1.84 perseant * (This should duplicate the fixup in lfs_gatherpages().)
1793 1.84 perseant */
1794 1.84 perseant sp->vp = vp;
1795 1.86 perseant sp->fip->fi_version = ip->i_ffs_gen;
1796 1.86 perseant sp->fip->fi_ino = ip->i_number;
1797 1.86 perseant /* Add us to the new segment summary. */
1798 1.86 perseant ++((SEGSUM *)(sp->segsum))->ss_nfinfo;
1799 1.86 perseant sp->sum_bytes_left -=
1800 1.86 perseant sizeof(struct finfo) - sizeof(int32_t);
1801 1.84 perseant
1802 1.84 perseant /* Give the write a chance to complete */
1803 1.84 perseant preempt(NULL);
1804 1.84 perseant simple_lock(&vp->v_interlock);
1805 1.84 perseant }
1806 1.84 perseant
1807 1.84 perseant /*
1808 1.84 perseant * Blocks are now gathered into a segment waiting to be written.
1809 1.84 perseant * All that's left to do is update metadata, and write them.
1810 1.84 perseant */
1811 1.84 perseant lfs_updatemeta(fs->lfs_sp);
1812 1.84 perseant fs->lfs_sp->vp = NULL;
1813 1.84 perseant /*
1814 1.88 perseant * Clean up FIP, since we're done writing this file.
1815 1.88 perseant * This should duplicate cleanup at the end of lfs_writefile().
1816 1.84 perseant */
1817 1.86 perseant if (sp->fip->fi_nblocks != 0) {
1818 1.86 perseant sp->fip = (FINFO*)((caddr_t)sp->fip + sizeof(struct finfo) +
1819 1.84 perseant sizeof(int32_t) * (sp->fip->fi_nblocks - 1));
1820 1.86 perseant sp->start_lbp = &sp->fip->fi_blocks[0];
1821 1.86 perseant } else {
1822 1.86 perseant sp->sum_bytes_left += sizeof(FINFO) - sizeof(int32_t);
1823 1.86 perseant --((SEGSUM *)(sp->segsum))->ss_nfinfo;
1824 1.86 perseant }
1825 1.88 perseant lfs_writeseg(fs, fs->lfs_sp);
1826 1.88 perseant
1827 1.84 perseant /*
1828 1.84 perseant * XXX - with the malloc/copy writeseg, the pages are freed by now
1829 1.84 perseant * even if we don't wait (e.g. if we hold a nested lock). This
1830 1.84 perseant * will not be true if we stop using malloc/copy.
1831 1.84 perseant */
1832 1.84 perseant KASSERT(fs->lfs_sp->seg_flags & SEGM_PROT);
1833 1.84 perseant lfs_segunlock(fs);
1834 1.84 perseant
1835 1.84 perseant /*
1836 1.84 perseant * Wait for v_numoutput to drop to zero. The seglock should
1837 1.84 perseant * take care of this, but there is a slight possibility that
1838 1.84 perseant * aiodoned might not have got around to our buffers yet.
1839 1.84 perseant */
1840 1.84 perseant if (sync) {
1841 1.84 perseant int s;
1842 1.84 perseant
1843 1.84 perseant s = splbio();
1844 1.84 perseant simple_lock(&global_v_numoutput_slock);
1845 1.84 perseant while(vp->v_numoutput > 0) {
1846 1.84 perseant #ifdef DEBUG
1847 1.84 perseant printf("ino %d sleeping on num %d\n",
1848 1.84 perseant ip->i_number, vp->v_numoutput);
1849 1.84 perseant #endif
1850 1.84 perseant vp->v_flag |= VBWAIT;
1851 1.87 yamt ltsleep(&vp->v_numoutput, PRIBIO + 1, "lfs_vn", 0,
1852 1.87 yamt &global_v_numoutput_slock);
1853 1.84 perseant }
1854 1.84 perseant simple_unlock(&global_v_numoutput_slock);
1855 1.84 perseant splx(s);
1856 1.84 perseant }
1857 1.84 perseant return error;
1858 1.84 perseant }
1859 1.84 perseant
1860 1.84 perseant /*
1861 1.84 perseant * Find out whether the vnode has any blocks or pages waiting to be written.
1862 1.84 perseant * We used to just check LIST_EMPTY(&vp->v_dirtyblkhd), but there is not
1863 1.84 perseant * presently as simple a mechanism for the page cache.
1864 1.84 perseant */
1865 1.84 perseant int
1866 1.84 perseant lfs_checkifempty(struct vnode *vp)
1867 1.84 perseant {
1868 1.84 perseant struct vm_page *pg;
1869 1.84 perseant struct buf *bp;
1870 1.84 perseant int r, s;
1871 1.84 perseant
1872 1.84 perseant if (vp->v_type != VREG || VTOI(vp)->i_number == LFS_IFILE_INUM)
1873 1.84 perseant return LIST_EMPTY(&vp->v_dirtyblkhd);
1874 1.84 perseant
1875 1.84 perseant /*
1876 1.84 perseant * For vnodes with pages it is a little more complex.
1877 1.84 perseant * Pages that have been written (i.e. are "clean" for our purposes)
1878 1.84 perseant * might be in seemingly dirty buffers, so we have to troll
1879 1.84 perseant * looking for indirect block buffers as well as pages.
1880 1.84 perseant */
1881 1.84 perseant simple_lock(&vp->v_interlock);
1882 1.84 perseant s = splbio();
1883 1.84 perseant for (bp = LIST_FIRST(&vp->v_dirtyblkhd); bp;
1884 1.84 perseant bp = LIST_NEXT(bp, b_vnbufs)) {
1885 1.84 perseant if (bp->b_lblkno < 0) {
1886 1.84 perseant splx(s);
1887 1.87 yamt simple_unlock(&vp->v_interlock);
1888 1.84 perseant return 0;
1889 1.84 perseant }
1890 1.84 perseant }
1891 1.84 perseant splx(s);
1892 1.84 perseant
1893 1.84 perseant /*
1894 1.84 perseant * Run through the page list to find dirty pages.
1895 1.84 perseant * Right now I just walk the memq.
1896 1.84 perseant */
1897 1.84 perseant pg = TAILQ_FIRST(&vp->v_uobj.memq);
1898 1.84 perseant r = 1;
1899 1.84 perseant while(pg) {
1900 1.84 perseant if ((pg->flags & PG_CLEAN) == 0 || pmap_is_modified(pg)) {
1901 1.84 perseant r = 0;
1902 1.84 perseant break;
1903 1.84 perseant }
1904 1.84 perseant pg = TAILQ_NEXT(pg, listq);
1905 1.84 perseant }
1906 1.84 perseant #if 0
1907 1.84 perseant if (r != !(vp->v_flag & VONWORKLST)) {
1908 1.84 perseant printf("nope, VONWORKLST isn't good enough!\n");
1909 1.84 perseant }
1910 1.84 perseant #endif
1911 1.84 perseant simple_unlock(&vp->v_interlock);
1912 1.84 perseant return r;
1913 1.84 perseant }
1914 1.84 perseant
1915 1.84 perseant /*
1916 1.84 perseant * Return the last logical file offset that should be written for this file
1917 1.86 perseant * if we're doing a write that ends at "size". If writing, we need to know
1918 1.84 perseant * about sizes on disk, i.e. fragments if there are any; if reading, we need
1919 1.84 perseant * to know about entire blocks.
1920 1.84 perseant */
1921 1.84 perseant void
1922 1.84 perseant lfs_gop_size(struct vnode *vp, off_t size, off_t *eobp, int flags)
1923 1.84 perseant {
1924 1.84 perseant struct inode *ip = VTOI(vp);
1925 1.84 perseant struct lfs *fs = ip->i_lfs;
1926 1.84 perseant daddr_t olbn, nlbn;
1927 1.84 perseant
1928 1.84 perseant KASSERT(flags & (GOP_SIZE_READ | GOP_SIZE_WRITE));
1929 1.84 perseant KASSERT((flags & (GOP_SIZE_READ | GOP_SIZE_WRITE))
1930 1.84 perseant != (GOP_SIZE_READ | GOP_SIZE_WRITE));
1931 1.84 perseant
1932 1.84 perseant olbn = lblkno(fs, ip->i_ffs_size);
1933 1.84 perseant nlbn = lblkno(fs, size);
1934 1.86 perseant if ((flags & GOP_SIZE_WRITE) && nlbn < NDADDR && olbn <= nlbn) {
1935 1.86 perseant *eobp = fragroundup(fs, size);
1936 1.86 perseant } else {
1937 1.86 perseant *eobp = blkroundup(fs, size);
1938 1.86 perseant }
1939 1.84 perseant }
1940 1.84 perseant
1941 1.84 perseant #ifdef DEBUG
1942 1.84 perseant void lfs_dump_vop(void *);
1943 1.84 perseant
1944 1.84 perseant void
1945 1.84 perseant lfs_dump_vop(void *v)
1946 1.84 perseant {
1947 1.86 perseant struct vop_putpages_args /* {
1948 1.86 perseant struct vnode *a_vp;
1949 1.86 perseant voff_t a_offlo;
1950 1.86 perseant voff_t a_offhi;
1951 1.86 perseant int a_flags;
1952 1.86 perseant } */ *ap = v;
1953 1.84 perseant
1954 1.84 perseant vfs_vnode_print(ap->a_vp, 0, printf);
1955 1.84 perseant lfs_dump_dinode(&VTOI(ap->a_vp)->i_din.ffs_din);
1956 1.84 perseant }
1957 1.84 perseant #endif
1958 1.84 perseant
1959 1.84 perseant int
1960 1.84 perseant lfs_mmap(void *v)
1961 1.84 perseant {
1962 1.84 perseant struct vop_mmap_args /* {
1963 1.86 perseant const struct vnodeop_desc *a_desc;
1964 1.86 perseant struct vnode *a_vp;
1965 1.86 perseant int a_fflags;
1966 1.86 perseant struct ucred *a_cred;
1967 1.86 perseant struct proc *a_p;
1968 1.84 perseant } */ *ap = v;
1969 1.84 perseant
1970 1.84 perseant if (VTOI(ap->a_vp)->i_number == LFS_IFILE_INUM)
1971 1.84 perseant return EOPNOTSUPP;
1972 1.84 perseant return ufs_mmap(v);
1973 1.84 perseant }
1974