lfs_vnops.c revision 1.264 1 1.264 dholland /* $NetBSD: lfs_vnops.c,v 1.264 2014/05/17 07:08:35 dholland 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 *
19 1.22 perseant * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20 1.22 perseant * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21 1.22 perseant * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22 1.22 perseant * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23 1.22 perseant * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 1.22 perseant * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 1.22 perseant * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 1.22 perseant * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 1.22 perseant * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 1.22 perseant * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 1.22 perseant * POSSIBILITY OF SUCH DAMAGE.
30 1.22 perseant */
31 1.1 mycroft /*
32 1.15 fvdl * Copyright (c) 1986, 1989, 1991, 1993, 1995
33 1.1 mycroft * The Regents of the University of California. All rights reserved.
34 1.1 mycroft *
35 1.1 mycroft * Redistribution and use in source and binary forms, with or without
36 1.1 mycroft * modification, are permitted provided that the following conditions
37 1.1 mycroft * are met:
38 1.1 mycroft * 1. Redistributions of source code must retain the above copyright
39 1.1 mycroft * notice, this list of conditions and the following disclaimer.
40 1.1 mycroft * 2. Redistributions in binary form must reproduce the above copyright
41 1.1 mycroft * notice, this list of conditions and the following disclaimer in the
42 1.1 mycroft * documentation and/or other materials provided with the distribution.
43 1.114 agc * 3. Neither the name of the University nor the names of its contributors
44 1.1 mycroft * may be used to endorse or promote products derived from this software
45 1.1 mycroft * without specific prior written permission.
46 1.1 mycroft *
47 1.1 mycroft * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
48 1.1 mycroft * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
49 1.1 mycroft * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
50 1.1 mycroft * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
51 1.1 mycroft * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
52 1.1 mycroft * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
53 1.1 mycroft * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
54 1.1 mycroft * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
55 1.1 mycroft * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
56 1.1 mycroft * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
57 1.1 mycroft * SUCH DAMAGE.
58 1.1 mycroft *
59 1.15 fvdl * @(#)lfs_vnops.c 8.13 (Berkeley) 6/10/95
60 1.1 mycroft */
61 1.58 lukem
62 1.58 lukem #include <sys/cdefs.h>
63 1.264 dholland __KERNEL_RCSID(0, "$NetBSD: lfs_vnops.c,v 1.264 2014/05/17 07:08:35 dholland Exp $");
64 1.182 martin
65 1.183 martin #ifdef _KERNEL_OPT
66 1.182 martin #include "opt_compat_netbsd.h"
67 1.238 chs #include "opt_uvm_page_trkown.h"
68 1.183 martin #endif
69 1.17 sommerfe
70 1.1 mycroft #include <sys/param.h>
71 1.1 mycroft #include <sys/systm.h>
72 1.1 mycroft #include <sys/namei.h>
73 1.1 mycroft #include <sys/resourcevar.h>
74 1.1 mycroft #include <sys/kernel.h>
75 1.1 mycroft #include <sys/file.h>
76 1.1 mycroft #include <sys/stat.h>
77 1.1 mycroft #include <sys/buf.h>
78 1.1 mycroft #include <sys/proc.h>
79 1.1 mycroft #include <sys/mount.h>
80 1.1 mycroft #include <sys/vnode.h>
81 1.19 thorpej #include <sys/pool.h>
82 1.10 christos #include <sys/signalvar.h>
83 1.176 elad #include <sys/kauth.h>
84 1.179 perseant #include <sys/syslog.h>
85 1.197 hannken #include <sys/fstrans.h>
86 1.1 mycroft
87 1.12 mycroft #include <miscfs/fifofs/fifo.h>
88 1.12 mycroft #include <miscfs/genfs/genfs.h>
89 1.1 mycroft #include <miscfs/specfs/specdev.h>
90 1.1 mycroft
91 1.244 dholland #include <ufs/lfs/ulfs_inode.h>
92 1.244 dholland #include <ufs/lfs/ulfsmount.h>
93 1.244 dholland #include <ufs/lfs/ulfs_bswap.h>
94 1.244 dholland #include <ufs/lfs/ulfs_extern.h>
95 1.1 mycroft
96 1.84 perseant #include <uvm/uvm.h>
97 1.95 perseant #include <uvm/uvm_pmap.h>
98 1.95 perseant #include <uvm/uvm_stat.h>
99 1.95 perseant #include <uvm/uvm_pager.h>
100 1.84 perseant
101 1.1 mycroft #include <ufs/lfs/lfs.h>
102 1.252 dholland #include <ufs/lfs/lfs_kernel.h>
103 1.1 mycroft #include <ufs/lfs/lfs_extern.h>
104 1.1 mycroft
105 1.91 yamt extern pid_t lfs_writer_daemon;
106 1.203 perseant int lfs_ignore_lazy_sync = 1;
107 1.203 perseant
108 1.254 dholland static int lfs_openextattr(void *v);
109 1.254 dholland static int lfs_closeextattr(void *v);
110 1.254 dholland static int lfs_getextattr(void *v);
111 1.254 dholland static int lfs_setextattr(void *v);
112 1.254 dholland static int lfs_listextattr(void *v);
113 1.254 dholland static int lfs_deleteextattr(void *v);
114 1.254 dholland
115 1.1 mycroft /* Global vfs data structures for lfs. */
116 1.51 perseant int (**lfs_vnodeop_p)(void *);
117 1.50 jdolecek const struct vnodeopv_entry_desc lfs_vnodeop_entries[] = {
118 1.1 mycroft { &vop_default_desc, vn_default_error },
119 1.245 dholland { &vop_lookup_desc, ulfs_lookup }, /* lookup */
120 1.22 perseant { &vop_create_desc, lfs_create }, /* create */
121 1.245 dholland { &vop_whiteout_desc, ulfs_whiteout }, /* whiteout */
122 1.22 perseant { &vop_mknod_desc, lfs_mknod }, /* mknod */
123 1.245 dholland { &vop_open_desc, ulfs_open }, /* open */
124 1.1 mycroft { &vop_close_desc, lfs_close }, /* close */
125 1.245 dholland { &vop_access_desc, ulfs_access }, /* access */
126 1.1 mycroft { &vop_getattr_desc, lfs_getattr }, /* getattr */
127 1.61 perseant { &vop_setattr_desc, lfs_setattr }, /* setattr */
128 1.1 mycroft { &vop_read_desc, lfs_read }, /* read */
129 1.1 mycroft { &vop_write_desc, lfs_write }, /* write */
130 1.245 dholland { &vop_ioctl_desc, ulfs_ioctl }, /* ioctl */
131 1.90 perseant { &vop_fcntl_desc, lfs_fcntl }, /* fcntl */
132 1.245 dholland { &vop_poll_desc, ulfs_poll }, /* poll */
133 1.68 jdolecek { &vop_kqfilter_desc, genfs_kqfilter }, /* kqfilter */
134 1.245 dholland { &vop_revoke_desc, ulfs_revoke }, /* revoke */
135 1.84 perseant { &vop_mmap_desc, lfs_mmap }, /* mmap */
136 1.1 mycroft { &vop_fsync_desc, lfs_fsync }, /* fsync */
137 1.245 dholland { &vop_seek_desc, ulfs_seek }, /* seek */
138 1.22 perseant { &vop_remove_desc, lfs_remove }, /* remove */
139 1.22 perseant { &vop_link_desc, lfs_link }, /* link */
140 1.22 perseant { &vop_rename_desc, lfs_rename }, /* rename */
141 1.22 perseant { &vop_mkdir_desc, lfs_mkdir }, /* mkdir */
142 1.22 perseant { &vop_rmdir_desc, lfs_rmdir }, /* rmdir */
143 1.22 perseant { &vop_symlink_desc, lfs_symlink }, /* symlink */
144 1.245 dholland { &vop_readdir_desc, ulfs_readdir }, /* readdir */
145 1.245 dholland { &vop_readlink_desc, ulfs_readlink }, /* readlink */
146 1.245 dholland { &vop_abortop_desc, ulfs_abortop }, /* abortop */
147 1.40 perseant { &vop_inactive_desc, lfs_inactive }, /* inactive */
148 1.1 mycroft { &vop_reclaim_desc, lfs_reclaim }, /* reclaim */
149 1.245 dholland { &vop_lock_desc, ulfs_lock }, /* lock */
150 1.245 dholland { &vop_unlock_desc, ulfs_unlock }, /* unlock */
151 1.245 dholland { &vop_bmap_desc, ulfs_bmap }, /* bmap */
152 1.94 perseant { &vop_strategy_desc, lfs_strategy }, /* strategy */
153 1.245 dholland { &vop_print_desc, ulfs_print }, /* print */
154 1.245 dholland { &vop_islocked_desc, ulfs_islocked }, /* islocked */
155 1.245 dholland { &vop_pathconf_desc, ulfs_pathconf }, /* pathconf */
156 1.245 dholland { &vop_advlock_desc, ulfs_advlock }, /* advlock */
157 1.1 mycroft { &vop_bwrite_desc, lfs_bwrite }, /* bwrite */
158 1.60 chs { &vop_getpages_desc, lfs_getpages }, /* getpages */
159 1.60 chs { &vop_putpages_desc, lfs_putpages }, /* putpages */
160 1.254 dholland { &vop_openextattr_desc, lfs_openextattr }, /* openextattr */
161 1.254 dholland { &vop_closeextattr_desc, lfs_closeextattr }, /* closeextattr */
162 1.254 dholland { &vop_getextattr_desc, lfs_getextattr }, /* getextattr */
163 1.254 dholland { &vop_setextattr_desc, lfs_setextattr }, /* setextattr */
164 1.254 dholland { &vop_listextattr_desc, lfs_listextattr }, /* listextattr */
165 1.254 dholland { &vop_deleteextattr_desc, lfs_deleteextattr }, /* deleteextattr */
166 1.53 chs { NULL, NULL }
167 1.1 mycroft };
168 1.50 jdolecek const struct vnodeopv_desc lfs_vnodeop_opv_desc =
169 1.1 mycroft { &lfs_vnodeop_p, lfs_vnodeop_entries };
170 1.1 mycroft
171 1.51 perseant int (**lfs_specop_p)(void *);
172 1.50 jdolecek const struct vnodeopv_entry_desc lfs_specop_entries[] = {
173 1.1 mycroft { &vop_default_desc, vn_default_error },
174 1.1 mycroft { &vop_lookup_desc, spec_lookup }, /* lookup */
175 1.1 mycroft { &vop_create_desc, spec_create }, /* create */
176 1.1 mycroft { &vop_mknod_desc, spec_mknod }, /* mknod */
177 1.1 mycroft { &vop_open_desc, spec_open }, /* open */
178 1.65 perseant { &vop_close_desc, lfsspec_close }, /* close */
179 1.245 dholland { &vop_access_desc, ulfs_access }, /* access */
180 1.1 mycroft { &vop_getattr_desc, lfs_getattr }, /* getattr */
181 1.61 perseant { &vop_setattr_desc, lfs_setattr }, /* setattr */
182 1.245 dholland { &vop_read_desc, ulfsspec_read }, /* read */
183 1.245 dholland { &vop_write_desc, ulfsspec_write }, /* write */
184 1.1 mycroft { &vop_ioctl_desc, spec_ioctl }, /* ioctl */
185 1.245 dholland { &vop_fcntl_desc, ulfs_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.245 dholland { &vop_lock_desc, ulfs_lock }, /* lock */
204 1.245 dholland { &vop_unlock_desc, ulfs_unlock }, /* unlock */
205 1.1 mycroft { &vop_bmap_desc, spec_bmap }, /* bmap */
206 1.1 mycroft { &vop_strategy_desc, spec_strategy }, /* strategy */
207 1.245 dholland { &vop_print_desc, ulfs_print }, /* print */
208 1.245 dholland { &vop_islocked_desc, ulfs_islocked }, /* islocked */
209 1.1 mycroft { &vop_pathconf_desc, spec_pathconf }, /* pathconf */
210 1.1 mycroft { &vop_advlock_desc, spec_advlock }, /* advlock */
211 1.28 perseant { &vop_bwrite_desc, vn_bwrite }, /* bwrite */
212 1.53 chs { &vop_getpages_desc, spec_getpages }, /* getpages */
213 1.53 chs { &vop_putpages_desc, spec_putpages }, /* putpages */
214 1.254 dholland { &vop_openextattr_desc, lfs_openextattr }, /* openextattr */
215 1.254 dholland { &vop_closeextattr_desc, lfs_closeextattr }, /* closeextattr */
216 1.254 dholland { &vop_getextattr_desc, lfs_getextattr }, /* getextattr */
217 1.254 dholland { &vop_setextattr_desc, lfs_setextattr }, /* setextattr */
218 1.254 dholland { &vop_listextattr_desc, lfs_listextattr }, /* listextattr */
219 1.254 dholland { &vop_deleteextattr_desc, lfs_deleteextattr }, /* deleteextattr */
220 1.53 chs { NULL, NULL }
221 1.1 mycroft };
222 1.50 jdolecek const struct vnodeopv_desc lfs_specop_opv_desc =
223 1.1 mycroft { &lfs_specop_p, lfs_specop_entries };
224 1.1 mycroft
225 1.51 perseant int (**lfs_fifoop_p)(void *);
226 1.50 jdolecek const struct vnodeopv_entry_desc lfs_fifoop_entries[] = {
227 1.1 mycroft { &vop_default_desc, vn_default_error },
228 1.227 pooka { &vop_lookup_desc, vn_fifo_bypass }, /* lookup */
229 1.227 pooka { &vop_create_desc, vn_fifo_bypass }, /* create */
230 1.227 pooka { &vop_mknod_desc, vn_fifo_bypass }, /* mknod */
231 1.227 pooka { &vop_open_desc, vn_fifo_bypass }, /* open */
232 1.65 perseant { &vop_close_desc, lfsfifo_close }, /* close */
233 1.245 dholland { &vop_access_desc, ulfs_access }, /* access */
234 1.1 mycroft { &vop_getattr_desc, lfs_getattr }, /* getattr */
235 1.61 perseant { &vop_setattr_desc, lfs_setattr }, /* setattr */
236 1.245 dholland { &vop_read_desc, ulfsfifo_read }, /* read */
237 1.245 dholland { &vop_write_desc, ulfsfifo_write }, /* write */
238 1.227 pooka { &vop_ioctl_desc, vn_fifo_bypass }, /* ioctl */
239 1.245 dholland { &vop_fcntl_desc, ulfs_fcntl }, /* fcntl */
240 1.227 pooka { &vop_poll_desc, vn_fifo_bypass }, /* poll */
241 1.227 pooka { &vop_kqfilter_desc, vn_fifo_bypass }, /* kqfilter */
242 1.227 pooka { &vop_revoke_desc, vn_fifo_bypass }, /* revoke */
243 1.227 pooka { &vop_mmap_desc, vn_fifo_bypass }, /* mmap */
244 1.227 pooka { &vop_fsync_desc, vn_fifo_bypass }, /* fsync */
245 1.227 pooka { &vop_seek_desc, vn_fifo_bypass }, /* seek */
246 1.227 pooka { &vop_remove_desc, vn_fifo_bypass }, /* remove */
247 1.227 pooka { &vop_link_desc, vn_fifo_bypass }, /* link */
248 1.227 pooka { &vop_rename_desc, vn_fifo_bypass }, /* rename */
249 1.227 pooka { &vop_mkdir_desc, vn_fifo_bypass }, /* mkdir */
250 1.227 pooka { &vop_rmdir_desc, vn_fifo_bypass }, /* rmdir */
251 1.227 pooka { &vop_symlink_desc, vn_fifo_bypass }, /* symlink */
252 1.227 pooka { &vop_readdir_desc, vn_fifo_bypass }, /* readdir */
253 1.227 pooka { &vop_readlink_desc, vn_fifo_bypass }, /* readlink */
254 1.227 pooka { &vop_abortop_desc, vn_fifo_bypass }, /* abortop */
255 1.40 perseant { &vop_inactive_desc, lfs_inactive }, /* inactive */
256 1.1 mycroft { &vop_reclaim_desc, lfs_reclaim }, /* reclaim */
257 1.245 dholland { &vop_lock_desc, ulfs_lock }, /* lock */
258 1.245 dholland { &vop_unlock_desc, ulfs_unlock }, /* unlock */
259 1.227 pooka { &vop_bmap_desc, vn_fifo_bypass }, /* bmap */
260 1.227 pooka { &vop_strategy_desc, vn_fifo_bypass }, /* strategy */
261 1.245 dholland { &vop_print_desc, ulfs_print }, /* print */
262 1.245 dholland { &vop_islocked_desc, ulfs_islocked }, /* islocked */
263 1.227 pooka { &vop_pathconf_desc, vn_fifo_bypass }, /* pathconf */
264 1.227 pooka { &vop_advlock_desc, vn_fifo_bypass }, /* advlock */
265 1.1 mycroft { &vop_bwrite_desc, lfs_bwrite }, /* bwrite */
266 1.227 pooka { &vop_putpages_desc, vn_fifo_bypass }, /* putpages */
267 1.254 dholland { &vop_openextattr_desc, lfs_openextattr }, /* openextattr */
268 1.254 dholland { &vop_closeextattr_desc, lfs_closeextattr }, /* closeextattr */
269 1.254 dholland { &vop_getextattr_desc, lfs_getextattr }, /* getextattr */
270 1.254 dholland { &vop_setextattr_desc, lfs_setextattr }, /* setextattr */
271 1.254 dholland { &vop_listextattr_desc, lfs_listextattr }, /* listextattr */
272 1.254 dholland { &vop_deleteextattr_desc, lfs_deleteextattr }, /* deleteextattr */
273 1.53 chs { NULL, NULL }
274 1.1 mycroft };
275 1.50 jdolecek const struct vnodeopv_desc lfs_fifoop_opv_desc =
276 1.1 mycroft { &lfs_fifoop_p, lfs_fifoop_entries };
277 1.1 mycroft
278 1.1 mycroft #define LFS_READWRITE
279 1.244 dholland #include <ufs/lfs/ulfs_readwrite.c>
280 1.1 mycroft #undef LFS_READWRITE
281 1.1 mycroft
282 1.1 mycroft /*
283 1.1 mycroft * Synch an open file.
284 1.1 mycroft */
285 1.1 mycroft /* ARGSUSED */
286 1.10 christos int
287 1.51 perseant lfs_fsync(void *v)
288 1.10 christos {
289 1.1 mycroft struct vop_fsync_args /* {
290 1.1 mycroft struct vnode *a_vp;
291 1.176 elad kauth_cred_t a_cred;
292 1.22 perseant int a_flags;
293 1.49 toshii off_t offlo;
294 1.49 toshii off_t offhi;
295 1.10 christos } */ *ap = v;
296 1.60 chs struct vnode *vp = ap->a_vp;
297 1.84 perseant int error, wait;
298 1.203 perseant struct inode *ip = VTOI(vp);
299 1.203 perseant struct lfs *fs = ip->i_lfs;
300 1.84 perseant
301 1.161 perseant /* If we're mounted read-only, don't try to sync. */
302 1.203 perseant if (fs->lfs_ronly)
303 1.161 perseant return 0;
304 1.161 perseant
305 1.231 hannken /* If a removed vnode is being cleaned, no need to sync here. */
306 1.231 hannken if ((ap->a_flags & FSYNC_RECLAIM) != 0 && ip->i_mode == 0)
307 1.231 hannken return 0;
308 1.231 hannken
309 1.86 perseant /*
310 1.203 perseant * Trickle sync simply adds this vnode to the pager list, as if
311 1.203 perseant * the pagedaemon had requested a pageout.
312 1.86 perseant */
313 1.84 perseant if (ap->a_flags & FSYNC_LAZY) {
314 1.203 perseant if (lfs_ignore_lazy_sync == 0) {
315 1.214 ad mutex_enter(&lfs_lock);
316 1.203 perseant if (!(ip->i_flags & IN_PAGING)) {
317 1.203 perseant ip->i_flags |= IN_PAGING;
318 1.203 perseant TAILQ_INSERT_TAIL(&fs->lfs_pchainhd, ip,
319 1.203 perseant i_lfs_pchain);
320 1.203 perseant }
321 1.203 perseant wakeup(&lfs_writer_daemon);
322 1.214 ad mutex_exit(&lfs_lock);
323 1.203 perseant }
324 1.47 perseant return 0;
325 1.84 perseant }
326 1.47 perseant
327 1.175 perseant /*
328 1.188 perseant * If a vnode is bring cleaned, flush it out before we try to
329 1.188 perseant * reuse it. This prevents the cleaner from writing files twice
330 1.188 perseant * in the same partial segment, causing an accounting underflow.
331 1.188 perseant */
332 1.203 perseant if (ap->a_flags & FSYNC_RECLAIM && ip->i_flags & IN_CLEANING) {
333 1.188 perseant lfs_vflush(vp);
334 1.175 perseant }
335 1.175 perseant
336 1.84 perseant wait = (ap->a_flags & FSYNC_WAIT);
337 1.203 perseant do {
338 1.235 rmind mutex_enter(vp->v_interlock);
339 1.203 perseant error = VOP_PUTPAGES(vp, trunc_page(ap->a_offlo),
340 1.203 perseant round_page(ap->a_offhi),
341 1.203 perseant PGO_CLEANIT | (wait ? PGO_SYNCIO : 0));
342 1.205 perseant if (error == EAGAIN) {
343 1.214 ad mutex_enter(&lfs_lock);
344 1.214 ad mtsleep(&fs->lfs_avail, PCATCH | PUSER, "lfs_fsync",
345 1.214 ad hz / 100 + 1, &lfs_lock);
346 1.214 ad mutex_exit(&lfs_lock);
347 1.205 perseant }
348 1.203 perseant } while (error == EAGAIN);
349 1.103 perseant if (error)
350 1.103 perseant return error;
351 1.203 perseant
352 1.203 perseant if ((ap->a_flags & FSYNC_DATAONLY) == 0)
353 1.203 perseant error = lfs_update(vp, NULL, NULL, wait ? UPDATE_WAIT : 0);
354 1.203 perseant
355 1.133 wrstuden if (error == 0 && ap->a_flags & FSYNC_CACHE) {
356 1.133 wrstuden int l = 0;
357 1.203 perseant error = VOP_IOCTL(ip->i_devvp, DIOCCACHESYNC, &l, FWRITE,
358 1.213 pooka curlwp->l_cred);
359 1.133 wrstuden }
360 1.103 perseant if (wait && !VPISEMPTY(vp))
361 1.203 perseant LFS_SET_UINO(ip, IN_MODIFIED);
362 1.84 perseant
363 1.63 perseant return error;
364 1.1 mycroft }
365 1.1 mycroft
366 1.1 mycroft /*
367 1.245 dholland * Take IN_ADIROP off, then call ulfs_inactive.
368 1.40 perseant */
369 1.40 perseant int
370 1.51 perseant lfs_inactive(void *v)
371 1.40 perseant {
372 1.40 perseant struct vop_inactive_args /* {
373 1.40 perseant struct vnode *a_vp;
374 1.40 perseant } */ *ap = v;
375 1.72 yamt
376 1.76 yamt lfs_unmark_vnode(ap->a_vp);
377 1.76 yamt
378 1.97 perseant /*
379 1.97 perseant * The Ifile is only ever inactivated on unmount.
380 1.97 perseant * Streamline this process by not giving it more dirty blocks.
381 1.97 perseant */
382 1.97 perseant if (VTOI(ap->a_vp)->i_number == LFS_IFILE_INUM) {
383 1.214 ad mutex_enter(&lfs_lock);
384 1.97 perseant LFS_CLR_UINO(VTOI(ap->a_vp), IN_ALLMOD);
385 1.214 ad mutex_exit(&lfs_lock);
386 1.229 hannken VOP_UNLOCK(ap->a_vp);
387 1.97 perseant return 0;
388 1.97 perseant }
389 1.97 perseant
390 1.239 perseant #ifdef DEBUG
391 1.239 perseant /*
392 1.239 perseant * This might happen on unmount.
393 1.239 perseant * XXX If it happens at any other time, it should be a panic.
394 1.239 perseant */
395 1.239 perseant if (ap->a_vp->v_uflag & VU_DIROP) {
396 1.239 perseant struct inode *ip = VTOI(ap->a_vp);
397 1.239 perseant printf("lfs_inactive: inactivating VU_DIROP? ino = %d\n", (int)ip->i_number);
398 1.239 perseant }
399 1.239 perseant #endif /* DIAGNOSTIC */
400 1.239 perseant
401 1.245 dholland return ulfs_inactive(v);
402 1.40 perseant }
403 1.40 perseant
404 1.249 dholland int
405 1.138 perseant lfs_set_dirop(struct vnode *dvp, struct vnode *vp)
406 1.40 perseant {
407 1.24 perseant struct lfs *fs;
408 1.24 perseant int error;
409 1.24 perseant
410 1.138 perseant KASSERT(VOP_ISLOCKED(dvp));
411 1.138 perseant KASSERT(vp == NULL || VOP_ISLOCKED(vp));
412 1.71 yamt
413 1.138 perseant fs = VTOI(dvp)->i_lfs;
414 1.141 perseant
415 1.141 perseant ASSERT_NO_SEGLOCK(fs);
416 1.44 perseant /*
417 1.134 perseant * LFS_NRESERVE calculates direct and indirect blocks as well
418 1.134 perseant * as an inode block; an overestimate in most cases.
419 1.44 perseant */
420 1.138 perseant if ((error = lfs_reserve(fs, dvp, vp, LFS_NRESERVE(fs))) != 0)
421 1.44 perseant return (error);
422 1.70 yamt
423 1.214 ad restart:
424 1.214 ad mutex_enter(&lfs_lock);
425 1.141 perseant if (fs->lfs_dirops == 0) {
426 1.214 ad mutex_exit(&lfs_lock);
427 1.138 perseant lfs_check(dvp, LFS_UNUSED_LBN, 0);
428 1.214 ad mutex_enter(&lfs_lock);
429 1.113 yamt }
430 1.190 perseant while (fs->lfs_writer) {
431 1.214 ad error = mtsleep(&fs->lfs_dirops, (PRIBIO + 1) | PCATCH,
432 1.214 ad "lfs_sdirop", 0, &lfs_lock);
433 1.190 perseant if (error == EINTR) {
434 1.214 ad mutex_exit(&lfs_lock);
435 1.190 perseant goto unreserve;
436 1.190 perseant }
437 1.190 perseant }
438 1.113 yamt if (lfs_dirvcount > LFS_MAX_DIROP && fs->lfs_dirops == 0) {
439 1.113 yamt wakeup(&lfs_writer_daemon);
440 1.214 ad mutex_exit(&lfs_lock);
441 1.198 ad preempt();
442 1.113 yamt goto restart;
443 1.113 yamt }
444 1.33 perseant
445 1.113 yamt if (lfs_dirvcount > LFS_MAX_DIROP) {
446 1.136 perseant DLOG((DLOG_DIROP, "lfs_set_dirop: sleeping with dirops=%d, "
447 1.136 perseant "dirvcount=%d\n", fs->lfs_dirops, lfs_dirvcount));
448 1.214 ad if ((error = mtsleep(&lfs_dirvcount,
449 1.214 ad PCATCH | PUSER | PNORELOCK, "lfs_maxdirop", 0,
450 1.214 ad &lfs_lock)) != 0) {
451 1.113 yamt goto unreserve;
452 1.113 yamt }
453 1.113 yamt goto restart;
454 1.135 perry }
455 1.113 yamt
456 1.135 perry ++fs->lfs_dirops;
457 1.239 perseant /* fs->lfs_doifile = 1; */ /* XXX why? --ks */
458 1.214 ad mutex_exit(&lfs_lock);
459 1.24 perseant
460 1.46 perseant /* Hold a reference so SET_ENDOP will be happy */
461 1.138 perseant vref(dvp);
462 1.138 perseant if (vp) {
463 1.138 perseant vref(vp);
464 1.138 perseant MARK_VNODE(vp);
465 1.138 perseant }
466 1.46 perseant
467 1.138 perseant MARK_VNODE(dvp);
468 1.24 perseant return 0;
469 1.70 yamt
470 1.203 perseant unreserve:
471 1.138 perseant lfs_reserve(fs, dvp, vp, -LFS_NRESERVE(fs));
472 1.70 yamt return error;
473 1.1 mycroft }
474 1.1 mycroft
475 1.138 perseant /*
476 1.264 dholland * Opposite of lfs_set_dirop... mostly. For now at least must call
477 1.264 dholland * UNMARK_VNODE(dvp) explicitly first. (XXX: clean that up)
478 1.138 perseant */
479 1.264 dholland void
480 1.264 dholland lfs_unset_dirop(struct lfs *fs, struct vnode *dvp, const char *str)
481 1.138 perseant {
482 1.264 dholland mutex_enter(&lfs_lock);
483 1.264 dholland --fs->lfs_dirops;
484 1.264 dholland if (!fs->lfs_dirops) {
485 1.264 dholland if (fs->lfs_nadirop) {
486 1.264 dholland panic("lfs_unset_dirop: %s: no dirops but "
487 1.264 dholland " nadirop=%d", str,
488 1.264 dholland fs->lfs_nadirop);
489 1.264 dholland }
490 1.264 dholland wakeup(&fs->lfs_writer);
491 1.264 dholland mutex_exit(&lfs_lock);
492 1.264 dholland lfs_check(dvp, LFS_UNUSED_LBN, 0);
493 1.264 dholland } else {
494 1.264 dholland mutex_exit(&lfs_lock);
495 1.138 perseant }
496 1.264 dholland lfs_reserve(fs, dvp, NULL, -LFS_NRESERVE(fs));
497 1.1 mycroft }
498 1.1 mycroft
499 1.117 yamt void
500 1.117 yamt lfs_mark_vnode(struct vnode *vp)
501 1.117 yamt {
502 1.117 yamt struct inode *ip = VTOI(vp);
503 1.117 yamt struct lfs *fs = ip->i_lfs;
504 1.37 perseant
505 1.214 ad mutex_enter(&lfs_lock);
506 1.117 yamt if (!(ip->i_flag & IN_ADIROP)) {
507 1.212 ad if (!(vp->v_uflag & VU_DIROP)) {
508 1.240 perseant mutex_exit(&lfs_lock);
509 1.235 rmind mutex_enter(vp->v_interlock);
510 1.239 perseant if (lfs_vref(vp) != 0)
511 1.239 perseant panic("lfs_mark_vnode: could not vref");
512 1.240 perseant mutex_enter(&lfs_lock);
513 1.117 yamt ++lfs_dirvcount;
514 1.173 perseant ++fs->lfs_dirvcount;
515 1.117 yamt TAILQ_INSERT_TAIL(&fs->lfs_dchainhd, ip, i_lfs_dchain);
516 1.212 ad vp->v_uflag |= VU_DIROP;
517 1.117 yamt }
518 1.117 yamt ++fs->lfs_nadirop;
519 1.239 perseant ip->i_flag &= ~IN_CDIROP;
520 1.117 yamt ip->i_flag |= IN_ADIROP;
521 1.117 yamt } else
522 1.212 ad KASSERT(vp->v_uflag & VU_DIROP);
523 1.214 ad mutex_exit(&lfs_lock);
524 1.117 yamt }
525 1.40 perseant
526 1.117 yamt void
527 1.117 yamt lfs_unmark_vnode(struct vnode *vp)
528 1.40 perseant {
529 1.117 yamt struct inode *ip = VTOI(vp);
530 1.40 perseant
531 1.240 perseant mutex_enter(&lfs_lock);
532 1.146 perseant if (ip && (ip->i_flag & IN_ADIROP)) {
533 1.212 ad KASSERT(vp->v_uflag & VU_DIROP);
534 1.40 perseant --ip->i_lfs->lfs_nadirop;
535 1.117 yamt ip->i_flag &= ~IN_ADIROP;
536 1.117 yamt }
537 1.240 perseant mutex_exit(&lfs_lock);
538 1.40 perseant }
539 1.15 fvdl
540 1.1 mycroft int
541 1.51 perseant lfs_symlink(void *v)
542 1.10 christos {
543 1.261 hannken struct vop_symlink_v3_args /* {
544 1.1 mycroft struct vnode *a_dvp;
545 1.1 mycroft struct vnode **a_vpp;
546 1.1 mycroft struct componentname *a_cnp;
547 1.1 mycroft struct vattr *a_vap;
548 1.1 mycroft char *a_target;
549 1.10 christos } */ *ap = v;
550 1.264 dholland struct lfs *fs;
551 1.264 dholland struct vnode *dvp, **vpp;
552 1.37 perseant int error;
553 1.1 mycroft
554 1.264 dholland dvp = ap->a_dvp;
555 1.264 dholland vpp = ap->a_vpp;
556 1.264 dholland
557 1.264 dholland KASSERT(vpp != NULL);
558 1.264 dholland KASSERT(*vpp == NULL);
559 1.264 dholland
560 1.264 dholland fs = VFSTOULFS(dvp->v_mount)->um_lfs;
561 1.264 dholland ASSERT_NO_SEGLOCK(fs);
562 1.264 dholland if (fs->lfs_ronly) {
563 1.264 dholland return EROFS;
564 1.264 dholland }
565 1.264 dholland
566 1.264 dholland /*
567 1.264 dholland * Get a new vnode *before* adjusting the dirop count, to
568 1.264 dholland * avoid a deadlock in getnewvnode(), if we have a stacked
569 1.264 dholland * filesystem mounted on top of us.
570 1.264 dholland *
571 1.264 dholland * NB: this means we have to destroy the new vnode on error.
572 1.264 dholland */
573 1.264 dholland
574 1.264 dholland error = getnewvnode(VT_LFS, dvp->v_mount, lfs_vnodeop_p, NULL, vpp);
575 1.264 dholland if (error) {
576 1.264 dholland DLOG((DLOG_ALLOC, "lfs_mkdir: dvp %p error %d\n", dvp, error));
577 1.264 dholland return error;
578 1.264 dholland }
579 1.264 dholland KASSERT(*vpp != NULL);
580 1.264 dholland
581 1.264 dholland error = lfs_set_dirop(dvp, NULL);
582 1.264 dholland if (error) {
583 1.264 dholland ungetnewvnode(*vpp);
584 1.264 dholland *vpp = NULL;
585 1.37 perseant return error;
586 1.34 perseant }
587 1.264 dholland
588 1.245 dholland error = ulfs_symlink(ap);
589 1.264 dholland
590 1.264 dholland UNMARK_VNODE(dvp);
591 1.264 dholland /* XXX: is it even possible for the symlink to get MARK'd? */
592 1.264 dholland UNMARK_VNODE(*vpp);
593 1.264 dholland if (!((*vpp)->v_uflag & VU_DIROP)) {
594 1.264 dholland KASSERT(error != 0);
595 1.264 dholland ungetnewvnode(*vpp);
596 1.264 dholland *vpp = NULL;
597 1.264 dholland }
598 1.264 dholland else {
599 1.264 dholland KASSERT(error == 0);
600 1.264 dholland }
601 1.264 dholland lfs_unset_dirop(fs, dvp, "symlink");
602 1.264 dholland
603 1.264 dholland vrele(dvp);
604 1.37 perseant return (error);
605 1.1 mycroft }
606 1.1 mycroft
607 1.1 mycroft int
608 1.51 perseant lfs_mknod(void *v)
609 1.10 christos {
610 1.261 hannken struct vop_mknod_v3_args /* {
611 1.1 mycroft struct vnode *a_dvp;
612 1.1 mycroft struct vnode **a_vpp;
613 1.1 mycroft struct componentname *a_cnp;
614 1.1 mycroft struct vattr *a_vap;
615 1.203 perseant } */ *ap = v;
616 1.264 dholland struct lfs *fs;
617 1.264 dholland struct vnode *dvp, **vpp;
618 1.250 dholland struct vattr *vap;
619 1.86 perseant struct inode *ip;
620 1.86 perseant int error;
621 1.135 perry struct mount *mp;
622 1.52 assar ino_t ino;
623 1.245 dholland struct ulfs_lookup_results *ulr;
624 1.237 dholland
625 1.264 dholland dvp = ap->a_dvp;
626 1.264 dholland vpp = ap->a_vpp;
627 1.250 dholland vap = ap->a_vap;
628 1.250 dholland
629 1.264 dholland KASSERT(vpp != NULL);
630 1.264 dholland KASSERT(*vpp == NULL);
631 1.264 dholland
632 1.237 dholland /* XXX should handle this material another way */
633 1.264 dholland ulr = &VTOI(dvp)->i_crap;
634 1.264 dholland ULFS_CHECK_CRAPCOUNTER(VTOI(dvp));
635 1.264 dholland
636 1.264 dholland fs = VFSTOULFS(dvp->v_mount)->um_lfs;
637 1.264 dholland ASSERT_NO_SEGLOCK(fs);
638 1.264 dholland if (fs->lfs_ronly) {
639 1.264 dholland return EROFS;
640 1.264 dholland }
641 1.264 dholland
642 1.264 dholland /*
643 1.264 dholland * Get a new vnode *before* adjusting the dirop count, to
644 1.264 dholland * avoid a deadlock in getnewvnode(), if we have a stacked
645 1.264 dholland * filesystem mounted on top of us.
646 1.264 dholland *
647 1.264 dholland * NB: this means we have to destroy the new vnode on error.
648 1.264 dholland */
649 1.264 dholland
650 1.264 dholland error = getnewvnode(VT_LFS, dvp->v_mount, lfs_vnodeop_p, NULL, vpp);
651 1.264 dholland if (error) {
652 1.264 dholland DLOG((DLOG_ALLOC, "lfs_mknod: dvp %p error %d\n", dvp, error));
653 1.264 dholland return error;
654 1.264 dholland }
655 1.264 dholland KASSERT(*vpp != NULL);
656 1.1 mycroft
657 1.264 dholland error = lfs_set_dirop(dvp, NULL);
658 1.264 dholland if (error) {
659 1.264 dholland ungetnewvnode(*vpp);
660 1.264 dholland *vpp = NULL;
661 1.28 perseant return error;
662 1.34 perseant }
663 1.250 dholland
664 1.250 dholland fstrans_start(ap->a_dvp->v_mount, FSTRANS_SHARED);
665 1.245 dholland error = ulfs_makeinode(MAKEIMODE(vap->va_type, vap->va_mode),
666 1.264 dholland dvp, ulr, vpp, ap->a_cnp);
667 1.28 perseant
668 1.28 perseant /* Either way we're done with the dirop at this point */
669 1.264 dholland UNMARK_VNODE(dvp);
670 1.264 dholland UNMARK_VNODE(*vpp);
671 1.264 dholland if (!((*vpp)->v_uflag & VU_DIROP)) {
672 1.264 dholland KASSERT(error != 0);
673 1.264 dholland ungetnewvnode(*vpp);
674 1.264 dholland *vpp = NULL;
675 1.264 dholland }
676 1.264 dholland else {
677 1.264 dholland KASSERT(error == 0);
678 1.264 dholland }
679 1.264 dholland lfs_unset_dirop(fs, dvp, "mknod");
680 1.264 dholland /*
681 1.264 dholland * XXX this is where this used to be (though inside some evil
682 1.264 dholland * macros) but it clearly should be moved further down.
683 1.264 dholland * - dholland 20140515
684 1.264 dholland */
685 1.264 dholland vrele(dvp);
686 1.28 perseant
687 1.250 dholland if (error) {
688 1.250 dholland fstrans_done(ap->a_dvp->v_mount);
689 1.250 dholland *vpp = NULL;
690 1.28 perseant return (error);
691 1.250 dholland }
692 1.28 perseant
693 1.264 dholland VN_KNOTE(dvp, NOTE_WRITE);
694 1.86 perseant ip = VTOI(*vpp);
695 1.52 assar mp = (*vpp)->v_mount;
696 1.52 assar ino = ip->i_number;
697 1.86 perseant ip->i_flag |= IN_ACCESS | IN_CHANGE | IN_UPDATE;
698 1.86 perseant if (vap->va_rdev != VNOVAL) {
699 1.250 dholland struct ulfsmount *ump = ip->i_ump;
700 1.264 dholland KASSERT(fs == ip->i_lfs);
701 1.86 perseant /*
702 1.86 perseant * Want to be able to use this to make badblock
703 1.86 perseant * inodes, so don't truncate the dev number.
704 1.86 perseant */
705 1.250 dholland if (ump->um_fstype == ULFS1)
706 1.250 dholland ip->i_ffs1_rdev = ulfs_rw32(vap->va_rdev,
707 1.253 dholland ULFS_MPNEEDSWAP(fs));
708 1.250 dholland else
709 1.250 dholland ip->i_ffs2_rdev = ulfs_rw64(vap->va_rdev,
710 1.253 dholland ULFS_MPNEEDSWAP(fs));
711 1.86 perseant }
712 1.134 perseant
713 1.28 perseant /*
714 1.28 perseant * Call fsync to write the vnode so that we don't have to deal with
715 1.262 hannken * flushing it when it's marked VU_DIROP or reclaiming.
716 1.28 perseant *
717 1.28 perseant * XXX KS - If we can't flush we also can't call vgone(), so must
718 1.28 perseant * return. But, that leaves this vnode in limbo, also not good.
719 1.28 perseant * Can this ever happen (barring hardware failure)?
720 1.28 perseant */
721 1.213 pooka if ((error = VOP_FSYNC(*vpp, NOCRED, FSYNC_WAIT, 0, 0)) != 0) {
722 1.153 christos panic("lfs_mknod: couldn't fsync (ino %llu)",
723 1.203 perseant (unsigned long long)ino);
724 1.136 perseant /* return (error); */
725 1.40 perseant }
726 1.86 perseant /*
727 1.86 perseant * Remove vnode so that it will be reloaded by VFS_VGET and
728 1.86 perseant * checked to see if it is an alias of an existing entry in
729 1.86 perseant * the inode cache.
730 1.86 perseant */
731 1.28 perseant /* Used to be vput, but that causes us to call VOP_INACTIVE twice. */
732 1.134 perseant
733 1.250 dholland (*vpp)->v_type = VNON;
734 1.229 hannken VOP_UNLOCK(*vpp);
735 1.86 perseant vgone(*vpp);
736 1.108 thorpej error = VFS_VGET(mp, ino, vpp);
737 1.134 perseant
738 1.250 dholland fstrans_done(ap->a_dvp->v_mount);
739 1.52 assar if (error != 0) {
740 1.52 assar *vpp = NULL;
741 1.52 assar return (error);
742 1.52 assar }
743 1.261 hannken VOP_UNLOCK(*vpp);
744 1.86 perseant return (0);
745 1.1 mycroft }
746 1.1 mycroft
747 1.1 mycroft int
748 1.51 perseant lfs_create(void *v)
749 1.10 christos {
750 1.261 hannken struct vop_create_v3_args /* {
751 1.1 mycroft struct vnode *a_dvp;
752 1.1 mycroft struct vnode **a_vpp;
753 1.1 mycroft struct componentname *a_cnp;
754 1.1 mycroft struct vattr *a_vap;
755 1.10 christos } */ *ap = v;
756 1.264 dholland struct lfs *fs;
757 1.264 dholland struct vnode *dvp, **vpp;
758 1.37 perseant int error;
759 1.1 mycroft
760 1.264 dholland dvp = ap->a_dvp;
761 1.264 dholland vpp = ap->a_vpp;
762 1.264 dholland
763 1.264 dholland KASSERT(vpp != NULL);
764 1.264 dholland KASSERT(*vpp == NULL);
765 1.264 dholland
766 1.264 dholland fs = VFSTOULFS(dvp->v_mount)->um_lfs;
767 1.264 dholland ASSERT_NO_SEGLOCK(fs);
768 1.264 dholland if (fs->lfs_ronly) {
769 1.264 dholland return EROFS;
770 1.264 dholland }
771 1.264 dholland
772 1.264 dholland /*
773 1.264 dholland * Get a new vnode *before* adjusting the dirop count, to
774 1.264 dholland * avoid a deadlock in getnewvnode(), if we have a stacked
775 1.264 dholland * filesystem mounted on top of us.
776 1.264 dholland *
777 1.264 dholland * NB: this means we have to destroy the new vnode on error.
778 1.264 dholland */
779 1.264 dholland
780 1.264 dholland error = getnewvnode(VT_LFS, dvp->v_mount, lfs_vnodeop_p, NULL, vpp);
781 1.264 dholland if (error) {
782 1.264 dholland DLOG((DLOG_ALLOC, "lfs_create: dvp %p error %d\n", dvp,error));
783 1.264 dholland return error;
784 1.264 dholland }
785 1.264 dholland error = lfs_set_dirop(dvp, NULL);
786 1.264 dholland if (error) {
787 1.264 dholland ungetnewvnode(*vpp);
788 1.264 dholland *vpp = NULL;
789 1.37 perseant return error;
790 1.34 perseant }
791 1.264 dholland
792 1.245 dholland error = ulfs_create(ap);
793 1.264 dholland
794 1.264 dholland UNMARK_VNODE(dvp);
795 1.264 dholland UNMARK_VNODE(*vpp);
796 1.264 dholland if (!((*vpp)->v_uflag & VU_DIROP)) {
797 1.264 dholland KASSERT(error != 0);
798 1.264 dholland ungetnewvnode(*vpp);
799 1.264 dholland *vpp = NULL;
800 1.264 dholland }
801 1.264 dholland else {
802 1.264 dholland KASSERT(error == 0);
803 1.264 dholland }
804 1.264 dholland lfs_unset_dirop(fs, dvp, "create");
805 1.264 dholland
806 1.264 dholland vrele(dvp);
807 1.37 perseant return (error);
808 1.22 perseant }
809 1.22 perseant
810 1.22 perseant int
811 1.51 perseant lfs_mkdir(void *v)
812 1.10 christos {
813 1.261 hannken struct vop_mkdir_v3_args /* {
814 1.1 mycroft struct vnode *a_dvp;
815 1.1 mycroft struct vnode **a_vpp;
816 1.1 mycroft struct componentname *a_cnp;
817 1.1 mycroft struct vattr *a_vap;
818 1.10 christos } */ *ap = v;
819 1.264 dholland struct lfs *fs;
820 1.264 dholland struct vnode *dvp, **vpp;
821 1.37 perseant int error;
822 1.1 mycroft
823 1.264 dholland dvp = ap->a_dvp;
824 1.264 dholland vpp = ap->a_vpp;
825 1.264 dholland
826 1.264 dholland KASSERT(vpp != NULL);
827 1.264 dholland KASSERT(*vpp == NULL);
828 1.264 dholland
829 1.264 dholland fs = VFSTOULFS(dvp->v_mount)->um_lfs;
830 1.264 dholland ASSERT_NO_SEGLOCK(fs);
831 1.264 dholland if (fs->lfs_ronly) {
832 1.264 dholland return EROFS;
833 1.264 dholland }
834 1.264 dholland
835 1.264 dholland /*
836 1.264 dholland * Get a new vnode *before* adjusting the dirop count, to
837 1.264 dholland * avoid a deadlock in getnewvnode(), if we have a stacked
838 1.264 dholland * filesystem mounted on top of us.
839 1.264 dholland *
840 1.264 dholland * NB: this means we have to destroy the new vnode on error.
841 1.264 dholland */
842 1.264 dholland
843 1.264 dholland error = getnewvnode(VT_LFS, dvp->v_mount, lfs_vnodeop_p, NULL, vpp);
844 1.264 dholland if (error) {
845 1.264 dholland DLOG((DLOG_ALLOC, "lfs_mkdir: dvp %p error %d\n", dvp, error));
846 1.264 dholland return error;
847 1.264 dholland }
848 1.264 dholland error = lfs_set_dirop(dvp, NULL);
849 1.264 dholland if (error) {
850 1.264 dholland ungetnewvnode(*vpp);
851 1.264 dholland *vpp = NULL;
852 1.37 perseant return error;
853 1.34 perseant }
854 1.264 dholland
855 1.245 dholland error = ulfs_mkdir(ap);
856 1.264 dholland
857 1.264 dholland UNMARK_VNODE(dvp);
858 1.264 dholland UNMARK_VNODE(*vpp);
859 1.264 dholland if (!((*vpp)->v_uflag & VU_DIROP)) {
860 1.264 dholland KASSERT(error != 0);
861 1.264 dholland ungetnewvnode(*vpp);
862 1.264 dholland *vpp = NULL;
863 1.264 dholland }
864 1.264 dholland else {
865 1.264 dholland KASSERT(error == 0);
866 1.264 dholland }
867 1.264 dholland lfs_unset_dirop(fs, dvp, "mkdir");
868 1.264 dholland
869 1.264 dholland vrele(dvp);
870 1.37 perseant return (error);
871 1.1 mycroft }
872 1.1 mycroft
873 1.1 mycroft int
874 1.51 perseant lfs_remove(void *v)
875 1.10 christos {
876 1.22 perseant struct vop_remove_args /* {
877 1.1 mycroft struct vnode *a_dvp;
878 1.1 mycroft struct vnode *a_vp;
879 1.1 mycroft struct componentname *a_cnp;
880 1.10 christos } */ *ap = v;
881 1.34 perseant struct vnode *dvp, *vp;
882 1.188 perseant struct inode *ip;
883 1.37 perseant int error;
884 1.34 perseant
885 1.34 perseant dvp = ap->a_dvp;
886 1.34 perseant vp = ap->a_vp;
887 1.188 perseant ip = VTOI(vp);
888 1.264 dholland if ((error = lfs_set_dirop(dvp, vp)) != 0) {
889 1.34 perseant if (dvp == vp)
890 1.34 perseant vrele(vp);
891 1.34 perseant else
892 1.34 perseant vput(vp);
893 1.34 perseant vput(dvp);
894 1.37 perseant return error;
895 1.34 perseant }
896 1.245 dholland error = ulfs_remove(ap);
897 1.188 perseant if (ip->i_nlink == 0)
898 1.188 perseant lfs_orphan(ip->i_lfs, ip->i_number);
899 1.264 dholland
900 1.264 dholland UNMARK_VNODE(dvp);
901 1.264 dholland if (ap->a_vp) {
902 1.264 dholland UNMARK_VNODE(ap->a_vp);
903 1.264 dholland }
904 1.264 dholland lfs_unset_dirop(ip->i_lfs, dvp, "remove");
905 1.264 dholland vrele(dvp);
906 1.264 dholland if (ap->a_vp) {
907 1.264 dholland vrele(ap->a_vp);
908 1.264 dholland }
909 1.264 dholland
910 1.37 perseant return (error);
911 1.1 mycroft }
912 1.1 mycroft
913 1.1 mycroft int
914 1.51 perseant lfs_rmdir(void *v)
915 1.10 christos {
916 1.22 perseant struct vop_rmdir_args /* {
917 1.1 mycroft struct vnodeop_desc *a_desc;
918 1.1 mycroft struct vnode *a_dvp;
919 1.1 mycroft struct vnode *a_vp;
920 1.1 mycroft struct componentname *a_cnp;
921 1.10 christos } */ *ap = v;
922 1.84 perseant struct vnode *vp;
923 1.188 perseant struct inode *ip;
924 1.37 perseant int error;
925 1.1 mycroft
926 1.84 perseant vp = ap->a_vp;
927 1.188 perseant ip = VTOI(vp);
928 1.264 dholland if ((error = lfs_set_dirop(ap->a_dvp, ap->a_vp)) != 0) {
929 1.194 chs if (ap->a_dvp == vp)
930 1.194 chs vrele(ap->a_dvp);
931 1.194 chs else
932 1.194 chs vput(ap->a_dvp);
933 1.84 perseant vput(vp);
934 1.37 perseant return error;
935 1.34 perseant }
936 1.245 dholland error = ulfs_rmdir(ap);
937 1.188 perseant if (ip->i_nlink == 0)
938 1.188 perseant lfs_orphan(ip->i_lfs, ip->i_number);
939 1.264 dholland
940 1.264 dholland UNMARK_VNODE(ap->a_dvp);
941 1.264 dholland if (ap->a_vp) {
942 1.264 dholland UNMARK_VNODE(ap->a_vp);
943 1.264 dholland }
944 1.264 dholland lfs_unset_dirop(ip->i_lfs, ap->a_dvp, "rmdir");
945 1.264 dholland vrele(ap->a_dvp);
946 1.264 dholland if (ap->a_vp) {
947 1.264 dholland vrele(ap->a_vp);
948 1.264 dholland }
949 1.264 dholland
950 1.37 perseant return (error);
951 1.1 mycroft }
952 1.1 mycroft
953 1.1 mycroft int
954 1.51 perseant lfs_link(void *v)
955 1.10 christos {
956 1.22 perseant struct vop_link_args /* {
957 1.9 mycroft struct vnode *a_dvp;
958 1.1 mycroft struct vnode *a_vp;
959 1.1 mycroft struct componentname *a_cnp;
960 1.10 christos } */ *ap = v;
961 1.264 dholland struct lfs *fs;
962 1.264 dholland struct vnode *dvp, **vpp;
963 1.37 perseant int error;
964 1.1 mycroft
965 1.264 dholland dvp = ap->a_dvp;
966 1.264 dholland vpp = NULL;
967 1.264 dholland
968 1.264 dholland fs = VFSTOULFS(dvp->v_mount)->um_lfs;
969 1.264 dholland ASSERT_NO_SEGLOCK(fs);
970 1.264 dholland if (fs->lfs_ronly) {
971 1.264 dholland return EROFS;
972 1.264 dholland }
973 1.264 dholland
974 1.264 dholland error = lfs_set_dirop(dvp, NULL);
975 1.264 dholland if (error) {
976 1.264 dholland /*
977 1.264 dholland * XXX dholland 20140515 this was here before but must
978 1.264 dholland * be wrong.
979 1.264 dholland */
980 1.264 dholland vput(dvp);
981 1.264 dholland
982 1.37 perseant return error;
983 1.34 perseant }
984 1.264 dholland
985 1.245 dholland error = ulfs_link(ap);
986 1.264 dholland
987 1.264 dholland UNMARK_VNODE(dvp);
988 1.264 dholland lfs_unset_dirop(fs, dvp, "link");
989 1.264 dholland vrele(dvp);
990 1.264 dholland
991 1.37 perseant return (error);
992 1.1 mycroft }
993 1.22 perseant
994 1.1 mycroft /* XXX hack to avoid calling ITIMES in getattr */
995 1.1 mycroft int
996 1.51 perseant lfs_getattr(void *v)
997 1.10 christos {
998 1.1 mycroft struct vop_getattr_args /* {
999 1.1 mycroft struct vnode *a_vp;
1000 1.1 mycroft struct vattr *a_vap;
1001 1.176 elad kauth_cred_t a_cred;
1002 1.10 christos } */ *ap = v;
1003 1.35 augustss struct vnode *vp = ap->a_vp;
1004 1.35 augustss struct inode *ip = VTOI(vp);
1005 1.35 augustss struct vattr *vap = ap->a_vap;
1006 1.51 perseant struct lfs *fs = ip->i_lfs;
1007 1.251 dholland
1008 1.251 dholland fstrans_start(vp->v_mount, FSTRANS_SHARED);
1009 1.1 mycroft /*
1010 1.1 mycroft * Copy from inode table
1011 1.1 mycroft */
1012 1.1 mycroft vap->va_fsid = ip->i_dev;
1013 1.1 mycroft vap->va_fileid = ip->i_number;
1014 1.246 dholland vap->va_mode = ip->i_mode & ~LFS_IFMT;
1015 1.102 fvdl vap->va_nlink = ip->i_nlink;
1016 1.102 fvdl vap->va_uid = ip->i_uid;
1017 1.102 fvdl vap->va_gid = ip->i_gid;
1018 1.102 fvdl vap->va_rdev = (dev_t)ip->i_ffs1_rdev;
1019 1.55 chs vap->va_size = vp->v_size;
1020 1.102 fvdl vap->va_atime.tv_sec = ip->i_ffs1_atime;
1021 1.102 fvdl vap->va_atime.tv_nsec = ip->i_ffs1_atimensec;
1022 1.102 fvdl vap->va_mtime.tv_sec = ip->i_ffs1_mtime;
1023 1.102 fvdl vap->va_mtime.tv_nsec = ip->i_ffs1_mtimensec;
1024 1.102 fvdl vap->va_ctime.tv_sec = ip->i_ffs1_ctime;
1025 1.102 fvdl vap->va_ctime.tv_nsec = ip->i_ffs1_ctimensec;
1026 1.102 fvdl vap->va_flags = ip->i_flags;
1027 1.102 fvdl vap->va_gen = ip->i_gen;
1028 1.1 mycroft /* this doesn't belong here */
1029 1.1 mycroft if (vp->v_type == VBLK)
1030 1.1 mycroft vap->va_blocksize = BLKDEV_IOSIZE;
1031 1.1 mycroft else if (vp->v_type == VCHR)
1032 1.1 mycroft vap->va_blocksize = MAXBSIZE;
1033 1.1 mycroft else
1034 1.1 mycroft vap->va_blocksize = vp->v_mount->mnt_stat.f_iosize;
1035 1.248 christos vap->va_bytes = lfs_fsbtob(fs, (u_quad_t)ip->i_lfs_effnblks);
1036 1.1 mycroft vap->va_type = vp->v_type;
1037 1.1 mycroft vap->va_filerev = ip->i_modrev;
1038 1.251 dholland fstrans_done(vp->v_mount);
1039 1.1 mycroft return (0);
1040 1.61 perseant }
1041 1.61 perseant
1042 1.61 perseant /*
1043 1.61 perseant * Check to make sure the inode blocks won't choke the buffer
1044 1.245 dholland * cache, then call ulfs_setattr as usual.
1045 1.61 perseant */
1046 1.61 perseant int
1047 1.61 perseant lfs_setattr(void *v)
1048 1.61 perseant {
1049 1.149 skrll struct vop_setattr_args /* {
1050 1.61 perseant struct vnode *a_vp;
1051 1.61 perseant struct vattr *a_vap;
1052 1.176 elad kauth_cred_t a_cred;
1053 1.61 perseant } */ *ap = v;
1054 1.61 perseant struct vnode *vp = ap->a_vp;
1055 1.61 perseant
1056 1.61 perseant lfs_check(vp, LFS_UNUSED_LBN, 0);
1057 1.245 dholland return ulfs_setattr(v);
1058 1.1 mycroft }
1059 1.22 perseant
1060 1.1 mycroft /*
1061 1.179 perseant * Release the block we hold on lfs_newseg wrapping. Called on file close,
1062 1.188 perseant * or explicitly from LFCNWRAPGO. Called with the interlock held.
1063 1.179 perseant */
1064 1.179 perseant static int
1065 1.193 christos lfs_wrapgo(struct lfs *fs, struct inode *ip, int waitfor)
1066 1.179 perseant {
1067 1.214 ad if (fs->lfs_stoplwp != curlwp)
1068 1.179 perseant return EBUSY;
1069 1.179 perseant
1070 1.214 ad fs->lfs_stoplwp = NULL;
1071 1.214 ad cv_signal(&fs->lfs_stopcv);
1072 1.179 perseant
1073 1.179 perseant KASSERT(fs->lfs_nowrap > 0);
1074 1.179 perseant if (fs->lfs_nowrap <= 0) {
1075 1.179 perseant return 0;
1076 1.179 perseant }
1077 1.179 perseant
1078 1.179 perseant if (--fs->lfs_nowrap == 0) {
1079 1.179 perseant log(LOG_NOTICE, "%s: re-enabled log wrap\n", fs->lfs_fsmnt);
1080 1.188 perseant wakeup(&fs->lfs_wrappass);
1081 1.180 perseant lfs_wakeup_cleaner(fs);
1082 1.179 perseant }
1083 1.179 perseant if (waitfor) {
1084 1.214 ad mtsleep(&fs->lfs_nextseg, PCATCH | PUSER, "segment",
1085 1.214 ad 0, &lfs_lock);
1086 1.179 perseant }
1087 1.179 perseant
1088 1.179 perseant return 0;
1089 1.179 perseant }
1090 1.179 perseant
1091 1.179 perseant /*
1092 1.251 dholland * Close called.
1093 1.251 dholland *
1094 1.251 dholland * Update the times on the inode.
1095 1.1 mycroft */
1096 1.1 mycroft /* ARGSUSED */
1097 1.1 mycroft int
1098 1.51 perseant lfs_close(void *v)
1099 1.10 christos {
1100 1.1 mycroft struct vop_close_args /* {
1101 1.1 mycroft struct vnode *a_vp;
1102 1.1 mycroft int a_fflag;
1103 1.176 elad kauth_cred_t a_cred;
1104 1.10 christos } */ *ap = v;
1105 1.35 augustss struct vnode *vp = ap->a_vp;
1106 1.35 augustss struct inode *ip = VTOI(vp);
1107 1.180 perseant struct lfs *fs = ip->i_lfs;
1108 1.1 mycroft
1109 1.245 dholland if ((ip->i_number == ULFS_ROOTINO || ip->i_number == LFS_IFILE_INUM) &&
1110 1.214 ad fs->lfs_stoplwp == curlwp) {
1111 1.214 ad mutex_enter(&lfs_lock);
1112 1.188 perseant log(LOG_NOTICE, "lfs_close: releasing log wrap control\n");
1113 1.180 perseant lfs_wrapgo(fs, ip, 0);
1114 1.214 ad mutex_exit(&lfs_lock);
1115 1.179 perseant }
1116 1.179 perseant
1117 1.97 perseant if (vp == ip->i_lfs->lfs_ivnode &&
1118 1.119 dbj vp->v_mount->mnt_iflag & IMNT_UNMOUNT)
1119 1.97 perseant return 0;
1120 1.97 perseant
1121 1.251 dholland fstrans_start(vp->v_mount, FSTRANS_SHARED);
1122 1.97 perseant if (vp->v_usecount > 1 && vp != ip->i_lfs->lfs_ivnode) {
1123 1.154 christos LFS_ITIMES(ip, NULL, NULL, NULL);
1124 1.1 mycroft }
1125 1.251 dholland fstrans_done(vp->v_mount);
1126 1.1 mycroft return (0);
1127 1.65 perseant }
1128 1.65 perseant
1129 1.65 perseant /*
1130 1.65 perseant * Close wrapper for special devices.
1131 1.65 perseant *
1132 1.65 perseant * Update the times on the inode then do device close.
1133 1.65 perseant */
1134 1.65 perseant int
1135 1.65 perseant lfsspec_close(void *v)
1136 1.65 perseant {
1137 1.65 perseant struct vop_close_args /* {
1138 1.65 perseant struct vnode *a_vp;
1139 1.65 perseant int a_fflag;
1140 1.176 elad kauth_cred_t a_cred;
1141 1.65 perseant } */ *ap = v;
1142 1.65 perseant struct vnode *vp;
1143 1.65 perseant struct inode *ip;
1144 1.65 perseant
1145 1.65 perseant vp = ap->a_vp;
1146 1.65 perseant ip = VTOI(vp);
1147 1.65 perseant if (vp->v_usecount > 1) {
1148 1.154 christos LFS_ITIMES(ip, NULL, NULL, NULL);
1149 1.65 perseant }
1150 1.65 perseant return (VOCALL (spec_vnodeop_p, VOFFSET(vop_close), ap));
1151 1.65 perseant }
1152 1.65 perseant
1153 1.65 perseant /*
1154 1.65 perseant * Close wrapper for fifo's.
1155 1.65 perseant *
1156 1.65 perseant * Update the times on the inode then do device close.
1157 1.65 perseant */
1158 1.65 perseant int
1159 1.65 perseant lfsfifo_close(void *v)
1160 1.65 perseant {
1161 1.65 perseant struct vop_close_args /* {
1162 1.65 perseant struct vnode *a_vp;
1163 1.65 perseant int a_fflag;
1164 1.176 elad kauth_cred_ a_cred;
1165 1.65 perseant } */ *ap = v;
1166 1.65 perseant struct vnode *vp;
1167 1.65 perseant struct inode *ip;
1168 1.65 perseant
1169 1.65 perseant vp = ap->a_vp;
1170 1.65 perseant ip = VTOI(vp);
1171 1.65 perseant if (ap->a_vp->v_usecount > 1) {
1172 1.154 christos LFS_ITIMES(ip, NULL, NULL, NULL);
1173 1.65 perseant }
1174 1.65 perseant return (VOCALL (fifo_vnodeop_p, VOFFSET(vop_close), ap));
1175 1.1 mycroft }
1176 1.1 mycroft
1177 1.1 mycroft /*
1178 1.15 fvdl * Reclaim an inode so that it can be used for other purposes.
1179 1.1 mycroft */
1180 1.1 mycroft
1181 1.1 mycroft int
1182 1.51 perseant lfs_reclaim(void *v)
1183 1.10 christos {
1184 1.1 mycroft struct vop_reclaim_args /* {
1185 1.1 mycroft struct vnode *a_vp;
1186 1.10 christos } */ *ap = v;
1187 1.15 fvdl struct vnode *vp = ap->a_vp;
1188 1.84 perseant struct inode *ip = VTOI(vp);
1189 1.203 perseant struct lfs *fs = ip->i_lfs;
1190 1.1 mycroft int error;
1191 1.77 yamt
1192 1.231 hannken /*
1193 1.231 hannken * The inode must be freed and updated before being removed
1194 1.231 hannken * from its hash chain. Other threads trying to gain a hold
1195 1.262 hannken * or lock on the inode will be stalled.
1196 1.231 hannken */
1197 1.231 hannken if (ip->i_nlink <= 0 && (vp->v_mount->mnt_flag & MNT_RDONLY) == 0)
1198 1.231 hannken lfs_vfree(vp, ip->i_number, ip->i_omode);
1199 1.231 hannken
1200 1.214 ad mutex_enter(&lfs_lock);
1201 1.84 perseant LFS_CLR_UINO(ip, IN_ALLMOD);
1202 1.214 ad mutex_exit(&lfs_lock);
1203 1.245 dholland if ((error = ulfs_reclaim(vp)))
1204 1.1 mycroft return (error);
1205 1.203 perseant
1206 1.203 perseant /*
1207 1.203 perseant * Take us off the paging and/or dirop queues if we were on them.
1208 1.203 perseant * We shouldn't be on them.
1209 1.203 perseant */
1210 1.214 ad mutex_enter(&lfs_lock);
1211 1.203 perseant if (ip->i_flags & IN_PAGING) {
1212 1.203 perseant log(LOG_WARNING, "%s: reclaimed vnode is IN_PAGING\n",
1213 1.203 perseant fs->lfs_fsmnt);
1214 1.203 perseant ip->i_flags &= ~IN_PAGING;
1215 1.203 perseant TAILQ_REMOVE(&fs->lfs_pchainhd, ip, i_lfs_pchain);
1216 1.203 perseant }
1217 1.212 ad if (vp->v_uflag & VU_DIROP) {
1218 1.212 ad panic("reclaimed vnode is VU_DIROP");
1219 1.212 ad vp->v_uflag &= ~VU_DIROP;
1220 1.203 perseant TAILQ_REMOVE(&fs->lfs_dchainhd, ip, i_lfs_dchain);
1221 1.203 perseant }
1222 1.214 ad mutex_exit(&lfs_lock);
1223 1.203 perseant
1224 1.142 perseant pool_put(&lfs_dinode_pool, ip->i_din.ffs1_din);
1225 1.145 perseant lfs_deregister_all(vp);
1226 1.84 perseant pool_put(&lfs_inoext_pool, ip->inode_ext.lfs);
1227 1.84 perseant ip->inode_ext.lfs = NULL;
1228 1.199 ad genfs_node_destroy(vp);
1229 1.19 thorpej pool_put(&lfs_inode_pool, vp->v_data);
1230 1.1 mycroft vp->v_data = NULL;
1231 1.94 perseant return (0);
1232 1.94 perseant }
1233 1.94 perseant
1234 1.94 perseant /*
1235 1.101 yamt * Read a block from a storage device.
1236 1.251 dholland *
1237 1.251 dholland * Calculate the logical to physical mapping if not done already,
1238 1.251 dholland * then call the device strategy routine.
1239 1.251 dholland *
1240 1.94 perseant * In order to avoid reading blocks that are in the process of being
1241 1.94 perseant * written by the cleaner---and hence are not mutexed by the normal
1242 1.94 perseant * buffer cache / page cache mechanisms---check for collisions before
1243 1.94 perseant * reading.
1244 1.94 perseant *
1245 1.245 dholland * We inline ulfs_strategy to make sure that the VOP_BMAP occurs *before*
1246 1.94 perseant * the active cleaner test.
1247 1.94 perseant *
1248 1.94 perseant * XXX This code assumes that lfs_markv makes synchronous checkpoints.
1249 1.94 perseant */
1250 1.94 perseant int
1251 1.94 perseant lfs_strategy(void *v)
1252 1.94 perseant {
1253 1.94 perseant struct vop_strategy_args /* {
1254 1.128 hannken struct vnode *a_vp;
1255 1.94 perseant struct buf *a_bp;
1256 1.94 perseant } */ *ap = v;
1257 1.94 perseant struct buf *bp;
1258 1.94 perseant struct lfs *fs;
1259 1.94 perseant struct vnode *vp;
1260 1.94 perseant struct inode *ip;
1261 1.94 perseant daddr_t tbn;
1262 1.239 perseant #define MAXLOOP 25
1263 1.239 perseant int i, sn, error, slept, loopcount;
1264 1.94 perseant
1265 1.94 perseant bp = ap->a_bp;
1266 1.128 hannken vp = ap->a_vp;
1267 1.94 perseant ip = VTOI(vp);
1268 1.94 perseant fs = ip->i_lfs;
1269 1.94 perseant
1270 1.101 yamt /* lfs uses its strategy routine only for read */
1271 1.101 yamt KASSERT(bp->b_flags & B_READ);
1272 1.101 yamt
1273 1.94 perseant if (vp->v_type == VBLK || vp->v_type == VCHR)
1274 1.94 perseant panic("lfs_strategy: spec");
1275 1.94 perseant KASSERT(bp->b_bcount != 0);
1276 1.94 perseant if (bp->b_blkno == bp->b_lblkno) {
1277 1.94 perseant error = VOP_BMAP(vp, bp->b_lblkno, NULL, &bp->b_blkno,
1278 1.94 perseant NULL);
1279 1.94 perseant if (error) {
1280 1.94 perseant bp->b_error = error;
1281 1.214 ad bp->b_resid = bp->b_bcount;
1282 1.94 perseant biodone(bp);
1283 1.94 perseant return (error);
1284 1.94 perseant }
1285 1.94 perseant if ((long)bp->b_blkno == -1) /* no valid data */
1286 1.94 perseant clrbuf(bp);
1287 1.94 perseant }
1288 1.94 perseant if ((long)bp->b_blkno < 0) { /* block is not on disk */
1289 1.214 ad bp->b_resid = bp->b_bcount;
1290 1.94 perseant biodone(bp);
1291 1.94 perseant return (0);
1292 1.94 perseant }
1293 1.94 perseant
1294 1.94 perseant slept = 1;
1295 1.239 perseant loopcount = 0;
1296 1.214 ad mutex_enter(&lfs_lock);
1297 1.101 yamt while (slept && fs->lfs_seglock) {
1298 1.214 ad mutex_exit(&lfs_lock);
1299 1.94 perseant /*
1300 1.94 perseant * Look through list of intervals.
1301 1.94 perseant * There will only be intervals to look through
1302 1.94 perseant * if the cleaner holds the seglock.
1303 1.94 perseant * Since the cleaner is synchronous, we can trust
1304 1.94 perseant * the list of intervals to be current.
1305 1.94 perseant */
1306 1.248 christos tbn = LFS_DBTOFSB(fs, bp->b_blkno);
1307 1.248 christos sn = lfs_dtosn(fs, tbn);
1308 1.94 perseant slept = 0;
1309 1.94 perseant for (i = 0; i < fs->lfs_cleanind; i++) {
1310 1.248 christos if (sn == lfs_dtosn(fs, fs->lfs_cleanint[i]) &&
1311 1.94 perseant tbn >= fs->lfs_cleanint[i]) {
1312 1.136 perseant DLOG((DLOG_CLEAN,
1313 1.136 perseant "lfs_strategy: ino %d lbn %" PRId64
1314 1.203 perseant " ind %d sn %d fsb %" PRIx32
1315 1.203 perseant " given sn %d fsb %" PRIx64 "\n",
1316 1.203 perseant ip->i_number, bp->b_lblkno, i,
1317 1.248 christos lfs_dtosn(fs, fs->lfs_cleanint[i]),
1318 1.203 perseant fs->lfs_cleanint[i], sn, tbn));
1319 1.136 perseant DLOG((DLOG_CLEAN,
1320 1.136 perseant "lfs_strategy: sleeping on ino %d lbn %"
1321 1.136 perseant PRId64 "\n", ip->i_number, bp->b_lblkno));
1322 1.214 ad mutex_enter(&lfs_lock);
1323 1.170 perseant if (LFS_SEGLOCK_HELD(fs) && fs->lfs_iocount) {
1324 1.239 perseant /*
1325 1.239 perseant * Cleaner can't wait for itself.
1326 1.239 perseant * Instead, wait for the blocks
1327 1.239 perseant * to be written to disk.
1328 1.239 perseant * XXX we need pribio in the test
1329 1.239 perseant * XXX here.
1330 1.239 perseant */
1331 1.239 perseant mtsleep(&fs->lfs_iocount,
1332 1.239 perseant (PRIBIO + 1) | PNORELOCK,
1333 1.239 perseant "clean2", hz/10 + 1,
1334 1.239 perseant &lfs_lock);
1335 1.170 perseant slept = 1;
1336 1.239 perseant ++loopcount;
1337 1.170 perseant break;
1338 1.170 perseant } else if (fs->lfs_seglock) {
1339 1.214 ad mtsleep(&fs->lfs_seglock,
1340 1.141 perseant (PRIBIO + 1) | PNORELOCK,
1341 1.170 perseant "clean1", 0,
1342 1.214 ad &lfs_lock);
1343 1.167 perseant slept = 1;
1344 1.167 perseant break;
1345 1.167 perseant }
1346 1.214 ad mutex_exit(&lfs_lock);
1347 1.94 perseant }
1348 1.94 perseant }
1349 1.214 ad mutex_enter(&lfs_lock);
1350 1.239 perseant if (loopcount > MAXLOOP) {
1351 1.239 perseant printf("lfs_strategy: breaking out of clean2 loop\n");
1352 1.239 perseant break;
1353 1.239 perseant }
1354 1.94 perseant }
1355 1.214 ad mutex_exit(&lfs_lock);
1356 1.94 perseant
1357 1.94 perseant vp = ip->i_devvp;
1358 1.251 dholland return VOP_STRATEGY(vp, bp);
1359 1.89 perseant }
1360 1.89 perseant
1361 1.239 perseant /*
1362 1.239 perseant * Inline lfs_segwrite/lfs_writevnodes, but just for dirops.
1363 1.239 perseant * Technically this is a checkpoint (the on-disk state is valid)
1364 1.239 perseant * even though we are leaving out all the file data.
1365 1.239 perseant */
1366 1.239 perseant int
1367 1.92 perseant lfs_flush_dirops(struct lfs *fs)
1368 1.92 perseant {
1369 1.92 perseant struct inode *ip, *nip;
1370 1.92 perseant struct vnode *vp;
1371 1.92 perseant extern int lfs_dostats;
1372 1.92 perseant struct segment *sp;
1373 1.239 perseant int flags = 0;
1374 1.239 perseant int error = 0;
1375 1.92 perseant
1376 1.163 perseant ASSERT_MAYBE_SEGLOCK(fs);
1377 1.171 perseant KASSERT(fs->lfs_nadirop == 0);
1378 1.141 perseant
1379 1.92 perseant if (fs->lfs_ronly)
1380 1.239 perseant return EROFS;
1381 1.92 perseant
1382 1.214 ad mutex_enter(&lfs_lock);
1383 1.141 perseant if (TAILQ_FIRST(&fs->lfs_dchainhd) == NULL) {
1384 1.214 ad mutex_exit(&lfs_lock);
1385 1.239 perseant return 0;
1386 1.141 perseant } else
1387 1.214 ad mutex_exit(&lfs_lock);
1388 1.92 perseant
1389 1.92 perseant if (lfs_dostats)
1390 1.92 perseant ++lfs_stats.flush_invoked;
1391 1.92 perseant
1392 1.92 perseant lfs_imtime(fs);
1393 1.239 perseant lfs_seglock(fs, flags);
1394 1.92 perseant sp = fs->lfs_sp;
1395 1.92 perseant
1396 1.92 perseant /*
1397 1.92 perseant * lfs_writevnodes, optimized to get dirops out of the way.
1398 1.92 perseant * Only write dirops, and don't flush files' pages, only
1399 1.92 perseant * blocks from the directories.
1400 1.92 perseant *
1401 1.92 perseant * We don't need to vref these files because they are
1402 1.92 perseant * dirops and so hold an extra reference until the
1403 1.92 perseant * segunlock clears them of that status.
1404 1.92 perseant *
1405 1.92 perseant * We don't need to check for IN_ADIROP because we know that
1406 1.92 perseant * no dirops are active.
1407 1.92 perseant *
1408 1.92 perseant */
1409 1.214 ad mutex_enter(&lfs_lock);
1410 1.92 perseant for (ip = TAILQ_FIRST(&fs->lfs_dchainhd); ip != NULL; ip = nip) {
1411 1.92 perseant nip = TAILQ_NEXT(ip, i_lfs_dchain);
1412 1.214 ad mutex_exit(&lfs_lock);
1413 1.92 perseant vp = ITOV(ip);
1414 1.262 hannken mutex_enter(vp->v_interlock);
1415 1.92 perseant
1416 1.171 perseant KASSERT((ip->i_flag & IN_ADIROP) == 0);
1417 1.239 perseant KASSERT(vp->v_uflag & VU_DIROP);
1418 1.262 hannken KASSERT(vdead_check(vp, VDEAD_NOWAIT) == 0);
1419 1.171 perseant
1420 1.92 perseant /*
1421 1.92 perseant * All writes to directories come from dirops; all
1422 1.92 perseant * writes to files' direct blocks go through the page
1423 1.92 perseant * cache, which we're not touching. Reads to files
1424 1.92 perseant * and/or directories will not be affected by writing
1425 1.92 perseant * directory blocks inodes and file inodes. So we don't
1426 1.239 perseant * really need to lock.
1427 1.92 perseant */
1428 1.262 hannken if (vdead_check(vp, VDEAD_NOWAIT) != 0) {
1429 1.262 hannken mutex_exit(vp->v_interlock);
1430 1.214 ad mutex_enter(&lfs_lock);
1431 1.92 perseant continue;
1432 1.167 perseant }
1433 1.262 hannken mutex_exit(vp->v_interlock);
1434 1.228 hannken /* XXX see below
1435 1.228 hannken * waslocked = VOP_ISLOCKED(vp);
1436 1.228 hannken */
1437 1.92 perseant if (vp->v_type != VREG &&
1438 1.92 perseant ((ip->i_flag & IN_ALLMOD) || !VPISEMPTY(vp))) {
1439 1.239 perseant error = lfs_writefile(fs, sp, vp);
1440 1.92 perseant if (!VPISEMPTY(vp) && !WRITEINPROG(vp) &&
1441 1.92 perseant !(ip->i_flag & IN_ALLMOD)) {
1442 1.214 ad mutex_enter(&lfs_lock);
1443 1.92 perseant LFS_SET_UINO(ip, IN_MODIFIED);
1444 1.214 ad mutex_exit(&lfs_lock);
1445 1.92 perseant }
1446 1.239 perseant if (error && (sp->seg_flags & SEGM_SINGLE)) {
1447 1.239 perseant mutex_enter(&lfs_lock);
1448 1.239 perseant error = EAGAIN;
1449 1.239 perseant break;
1450 1.239 perseant }
1451 1.92 perseant }
1452 1.188 perseant KDASSERT(ip->i_number != LFS_IFILE_INUM);
1453 1.239 perseant error = lfs_writeinode(fs, sp, ip);
1454 1.214 ad mutex_enter(&lfs_lock);
1455 1.239 perseant if (error && (sp->seg_flags & SEGM_SINGLE)) {
1456 1.239 perseant error = EAGAIN;
1457 1.239 perseant break;
1458 1.239 perseant }
1459 1.239 perseant
1460 1.228 hannken /*
1461 1.239 perseant * We might need to update these inodes again,
1462 1.239 perseant * for example, if they have data blocks to write.
1463 1.239 perseant * Make sure that after this flush, they are still
1464 1.239 perseant * marked IN_MODIFIED so that we don't forget to
1465 1.239 perseant * write them.
1466 1.228 hannken */
1467 1.239 perseant /* XXX only for non-directories? --KS */
1468 1.239 perseant LFS_SET_UINO(ip, IN_MODIFIED);
1469 1.92 perseant }
1470 1.214 ad mutex_exit(&lfs_lock);
1471 1.92 perseant /* We've written all the dirops there are */
1472 1.92 perseant ((SEGSUM *)(sp->segsum))->ss_flags &= ~(SS_CONT);
1473 1.170 perseant lfs_finalize_fs_seguse(fs);
1474 1.92 perseant (void) lfs_writeseg(fs, sp);
1475 1.92 perseant lfs_segunlock(fs);
1476 1.239 perseant
1477 1.239 perseant return error;
1478 1.92 perseant }
1479 1.92 perseant
1480 1.89 perseant /*
1481 1.164 perseant * Flush all vnodes for which the pagedaemon has requested pageouts.
1482 1.212 ad * Skip over any files that are marked VU_DIROP (since lfs_flush_dirop()
1483 1.164 perseant * has just run, this would be an error). If we have to skip a vnode
1484 1.164 perseant * for any reason, just skip it; if we have to wait for the cleaner,
1485 1.164 perseant * abort. The writer daemon will call us again later.
1486 1.164 perseant */
1487 1.239 perseant int
1488 1.164 perseant lfs_flush_pchain(struct lfs *fs)
1489 1.164 perseant {
1490 1.164 perseant struct inode *ip, *nip;
1491 1.164 perseant struct vnode *vp;
1492 1.164 perseant extern int lfs_dostats;
1493 1.164 perseant struct segment *sp;
1494 1.239 perseant int error, error2;
1495 1.164 perseant
1496 1.164 perseant ASSERT_NO_SEGLOCK(fs);
1497 1.164 perseant
1498 1.164 perseant if (fs->lfs_ronly)
1499 1.239 perseant return EROFS;
1500 1.164 perseant
1501 1.214 ad mutex_enter(&lfs_lock);
1502 1.164 perseant if (TAILQ_FIRST(&fs->lfs_pchainhd) == NULL) {
1503 1.214 ad mutex_exit(&lfs_lock);
1504 1.239 perseant return 0;
1505 1.164 perseant } else
1506 1.214 ad mutex_exit(&lfs_lock);
1507 1.164 perseant
1508 1.164 perseant /* Get dirops out of the way */
1509 1.239 perseant if ((error = lfs_flush_dirops(fs)) != 0)
1510 1.239 perseant return error;
1511 1.164 perseant
1512 1.164 perseant if (lfs_dostats)
1513 1.164 perseant ++lfs_stats.flush_invoked;
1514 1.164 perseant
1515 1.164 perseant /*
1516 1.164 perseant * Inline lfs_segwrite/lfs_writevnodes, but just for pageouts.
1517 1.164 perseant */
1518 1.164 perseant lfs_imtime(fs);
1519 1.164 perseant lfs_seglock(fs, 0);
1520 1.164 perseant sp = fs->lfs_sp;
1521 1.164 perseant
1522 1.164 perseant /*
1523 1.164 perseant * lfs_writevnodes, optimized to clear pageout requests.
1524 1.164 perseant * Only write non-dirop files that are in the pageout queue.
1525 1.164 perseant * We're very conservative about what we write; we want to be
1526 1.164 perseant * fast and async.
1527 1.164 perseant */
1528 1.214 ad mutex_enter(&lfs_lock);
1529 1.214 ad top:
1530 1.164 perseant for (ip = TAILQ_FIRST(&fs->lfs_pchainhd); ip != NULL; ip = nip) {
1531 1.164 perseant nip = TAILQ_NEXT(ip, i_lfs_pchain);
1532 1.164 perseant vp = ITOV(ip);
1533 1.164 perseant
1534 1.164 perseant if (!(ip->i_flags & IN_PAGING))
1535 1.164 perseant goto top;
1536 1.164 perseant
1537 1.235 rmind mutex_enter(vp->v_interlock);
1538 1.262 hannken if (vdead_check(vp, VDEAD_NOWAIT) != 0 ||
1539 1.262 hannken (vp->v_uflag & VU_DIROP) != 0) {
1540 1.235 rmind mutex_exit(vp->v_interlock);
1541 1.164 perseant continue;
1542 1.214 ad }
1543 1.214 ad if (vp->v_type != VREG) {
1544 1.235 rmind mutex_exit(vp->v_interlock);
1545 1.164 perseant continue;
1546 1.214 ad }
1547 1.164 perseant if (lfs_vref(vp))
1548 1.164 perseant continue;
1549 1.214 ad mutex_exit(&lfs_lock);
1550 1.169 perseant
1551 1.228 hannken if (vn_lock(vp, LK_EXCLUSIVE | LK_NOWAIT | LK_RETRY) != 0) {
1552 1.165 perseant lfs_vunref(vp);
1553 1.214 ad mutex_enter(&lfs_lock);
1554 1.164 perseant continue;
1555 1.165 perseant }
1556 1.164 perseant
1557 1.164 perseant error = lfs_writefile(fs, sp, vp);
1558 1.164 perseant if (!VPISEMPTY(vp) && !WRITEINPROG(vp) &&
1559 1.164 perseant !(ip->i_flag & IN_ALLMOD)) {
1560 1.214 ad mutex_enter(&lfs_lock);
1561 1.164 perseant LFS_SET_UINO(ip, IN_MODIFIED);
1562 1.214 ad mutex_exit(&lfs_lock);
1563 1.164 perseant }
1564 1.188 perseant KDASSERT(ip->i_number != LFS_IFILE_INUM);
1565 1.239 perseant error2 = lfs_writeinode(fs, sp, ip);
1566 1.164 perseant
1567 1.229 hannken VOP_UNLOCK(vp);
1568 1.164 perseant lfs_vunref(vp);
1569 1.164 perseant
1570 1.239 perseant if (error == EAGAIN || error2 == EAGAIN) {
1571 1.164 perseant lfs_writeseg(fs, sp);
1572 1.214 ad mutex_enter(&lfs_lock);
1573 1.164 perseant break;
1574 1.164 perseant }
1575 1.214 ad mutex_enter(&lfs_lock);
1576 1.164 perseant }
1577 1.214 ad mutex_exit(&lfs_lock);
1578 1.164 perseant (void) lfs_writeseg(fs, sp);
1579 1.164 perseant lfs_segunlock(fs);
1580 1.239 perseant
1581 1.239 perseant return 0;
1582 1.164 perseant }
1583 1.164 perseant
1584 1.164 perseant /*
1585 1.90 perseant * Provide a fcntl interface to sys_lfs_{segwait,bmapv,markv}.
1586 1.89 perseant */
1587 1.89 perseant int
1588 1.90 perseant lfs_fcntl(void *v)
1589 1.89 perseant {
1590 1.137 simonb struct vop_fcntl_args /* {
1591 1.137 simonb struct vnode *a_vp;
1592 1.218 gmcgarry u_int a_command;
1593 1.201 christos void * a_data;
1594 1.137 simonb int a_fflag;
1595 1.176 elad kauth_cred_t a_cred;
1596 1.137 simonb } */ *ap = v;
1597 1.222 christos struct timeval tv;
1598 1.89 perseant struct timeval *tvp;
1599 1.89 perseant BLOCK_INFO *blkiov;
1600 1.92 perseant CLEANERINFO *cip;
1601 1.148 perseant SEGUSE *sup;
1602 1.258 christos int blkcnt, error;
1603 1.181 martin size_t fh_size;
1604 1.90 perseant struct lfs_fcntl_markv blkvp;
1605 1.185 ad struct lwp *l;
1606 1.89 perseant fsid_t *fsidp;
1607 1.92 perseant struct lfs *fs;
1608 1.92 perseant struct buf *bp;
1609 1.134 perseant fhandle_t *fhp;
1610 1.92 perseant daddr_t off;
1611 1.258 christos int oclean;
1612 1.89 perseant
1613 1.90 perseant /* Only respect LFS fcntls on fs root or Ifile */
1614 1.245 dholland if (VTOI(ap->a_vp)->i_number != ULFS_ROOTINO &&
1615 1.89 perseant VTOI(ap->a_vp)->i_number != LFS_IFILE_INUM) {
1616 1.245 dholland return ulfs_fcntl(v);
1617 1.89 perseant }
1618 1.89 perseant
1619 1.100 perseant /* Avoid locking a draining lock */
1620 1.119 dbj if (ap->a_vp->v_mount->mnt_iflag & IMNT_UNMOUNT) {
1621 1.100 perseant return ESHUTDOWN;
1622 1.100 perseant }
1623 1.100 perseant
1624 1.184 perseant /* LFS control and monitoring fcntls are available only to root */
1625 1.213 pooka l = curlwp;
1626 1.184 perseant if (((ap->a_command & 0xff00) >> 8) == 'L' &&
1627 1.241 elad (error = kauth_authorize_system(l->l_cred, KAUTH_SYSTEM_LFS,
1628 1.241 elad KAUTH_REQ_SYSTEM_LFS_FCNTL, NULL, NULL, NULL)) != 0)
1629 1.184 perseant return (error);
1630 1.184 perseant
1631 1.100 perseant fs = VTOI(ap->a_vp)->i_lfs;
1632 1.131 christos fsidp = &ap->a_vp->v_mount->mnt_stat.f_fsidx;
1633 1.89 perseant
1634 1.188 perseant error = 0;
1635 1.218 gmcgarry switch ((int)ap->a_command) {
1636 1.222 christos case LFCNSEGWAITALL_COMPAT_50:
1637 1.222 christos case LFCNSEGWAITALL_COMPAT:
1638 1.222 christos fsidp = NULL;
1639 1.222 christos /* FALLSTHROUGH */
1640 1.222 christos case LFCNSEGWAIT_COMPAT_50:
1641 1.222 christos case LFCNSEGWAIT_COMPAT:
1642 1.222 christos {
1643 1.222 christos struct timeval50 *tvp50
1644 1.222 christos = (struct timeval50 *)ap->a_data;
1645 1.222 christos timeval50_to_timeval(tvp50, &tv);
1646 1.222 christos tvp = &tv;
1647 1.222 christos }
1648 1.222 christos goto segwait_common;
1649 1.90 perseant case LFCNSEGWAITALL:
1650 1.214 ad fsidp = NULL;
1651 1.214 ad /* FALLSTHROUGH */
1652 1.90 perseant case LFCNSEGWAIT:
1653 1.214 ad tvp = (struct timeval *)ap->a_data;
1654 1.222 christos segwait_common:
1655 1.214 ad mutex_enter(&lfs_lock);
1656 1.214 ad ++fs->lfs_sleepers;
1657 1.214 ad mutex_exit(&lfs_lock);
1658 1.214 ad
1659 1.214 ad error = lfs_segwait(fsidp, tvp);
1660 1.214 ad
1661 1.214 ad mutex_enter(&lfs_lock);
1662 1.214 ad if (--fs->lfs_sleepers == 0)
1663 1.214 ad wakeup(&fs->lfs_sleepers);
1664 1.214 ad mutex_exit(&lfs_lock);
1665 1.214 ad return error;
1666 1.89 perseant
1667 1.90 perseant case LFCNBMAPV:
1668 1.90 perseant case LFCNMARKV:
1669 1.214 ad blkvp = *(struct lfs_fcntl_markv *)ap->a_data;
1670 1.89 perseant
1671 1.214 ad blkcnt = blkvp.blkcnt;
1672 1.214 ad if ((u_int) blkcnt > LFS_MARKV_MAXBLKCNT)
1673 1.214 ad return (EINVAL);
1674 1.214 ad blkiov = lfs_malloc(fs, blkcnt * sizeof(BLOCK_INFO), LFS_NB_BLKIOV);
1675 1.214 ad if ((error = copyin(blkvp.blkiov, blkiov,
1676 1.214 ad blkcnt * sizeof(BLOCK_INFO))) != 0) {
1677 1.214 ad lfs_free(fs, blkiov, LFS_NB_BLKIOV);
1678 1.214 ad return error;
1679 1.214 ad }
1680 1.214 ad
1681 1.214 ad mutex_enter(&lfs_lock);
1682 1.214 ad ++fs->lfs_sleepers;
1683 1.214 ad mutex_exit(&lfs_lock);
1684 1.214 ad if (ap->a_command == LFCNBMAPV)
1685 1.214 ad error = lfs_bmapv(l->l_proc, fsidp, blkiov, blkcnt);
1686 1.214 ad else /* LFCNMARKV */
1687 1.214 ad error = lfs_markv(l->l_proc, fsidp, blkiov, blkcnt);
1688 1.214 ad if (error == 0)
1689 1.214 ad error = copyout(blkiov, blkvp.blkiov,
1690 1.214 ad blkcnt * sizeof(BLOCK_INFO));
1691 1.214 ad mutex_enter(&lfs_lock);
1692 1.214 ad if (--fs->lfs_sleepers == 0)
1693 1.214 ad wakeup(&fs->lfs_sleepers);
1694 1.214 ad mutex_exit(&lfs_lock);
1695 1.214 ad lfs_free(fs, blkiov, LFS_NB_BLKIOV);
1696 1.214 ad return error;
1697 1.92 perseant
1698 1.92 perseant case LFCNRECLAIM:
1699 1.214 ad /*
1700 1.214 ad * Flush dirops and write Ifile, allowing empty segments
1701 1.214 ad * to be immediately reclaimed.
1702 1.214 ad */
1703 1.214 ad lfs_writer_enter(fs, "pndirop");
1704 1.214 ad off = fs->lfs_offset;
1705 1.214 ad lfs_seglock(fs, SEGM_FORCE_CKP | SEGM_CKP);
1706 1.214 ad lfs_flush_dirops(fs);
1707 1.214 ad LFS_CLEANERINFO(cip, fs, bp);
1708 1.214 ad oclean = cip->clean;
1709 1.214 ad LFS_SYNC_CLEANERINFO(cip, fs, bp, 1);
1710 1.214 ad lfs_segwrite(ap->a_vp->v_mount, SEGM_FORCE_CKP);
1711 1.214 ad fs->lfs_sp->seg_flags |= SEGM_PROT;
1712 1.214 ad lfs_segunlock(fs);
1713 1.214 ad lfs_writer_leave(fs);
1714 1.92 perseant
1715 1.136 perseant #ifdef DEBUG
1716 1.214 ad LFS_CLEANERINFO(cip, fs, bp);
1717 1.214 ad DLOG((DLOG_CLEAN, "lfs_fcntl: reclaim wrote %" PRId64
1718 1.214 ad " blocks, cleaned %" PRId32 " segments (activesb %d)\n",
1719 1.214 ad fs->lfs_offset - off, cip->clean - oclean,
1720 1.214 ad fs->lfs_activesb));
1721 1.214 ad LFS_SYNC_CLEANERINFO(cip, fs, bp, 0);
1722 1.258 christos #else
1723 1.258 christos __USE(oclean);
1724 1.258 christos __USE(off);
1725 1.92 perseant #endif
1726 1.92 perseant
1727 1.214 ad return 0;
1728 1.89 perseant
1729 1.182 martin case LFCNIFILEFH_COMPAT:
1730 1.214 ad /* Return the filehandle of the Ifile */
1731 1.221 elad if ((error = kauth_authorize_system(l->l_cred,
1732 1.221 elad KAUTH_SYSTEM_FILEHANDLE, 0, NULL, NULL, NULL)) != 0)
1733 1.214 ad return (error);
1734 1.214 ad fhp = (struct fhandle *)ap->a_data;
1735 1.214 ad fhp->fh_fsid = *fsidp;
1736 1.214 ad fh_size = 16; /* former VFS_MAXFIDSIZ */
1737 1.214 ad return lfs_vptofh(fs->lfs_ivnode, &(fhp->fh_fid), &fh_size);
1738 1.182 martin
1739 1.187 martin case LFCNIFILEFH_COMPAT2:
1740 1.134 perseant case LFCNIFILEFH:
1741 1.214 ad /* Return the filehandle of the Ifile */
1742 1.214 ad fhp = (struct fhandle *)ap->a_data;
1743 1.214 ad fhp->fh_fsid = *fsidp;
1744 1.214 ad fh_size = sizeof(struct lfs_fhandle) -
1745 1.214 ad offsetof(fhandle_t, fh_fid);
1746 1.214 ad return lfs_vptofh(fs->lfs_ivnode, &(fhp->fh_fid), &fh_size);
1747 1.134 perseant
1748 1.148 perseant case LFCNREWIND:
1749 1.214 ad /* Move lfs_offset to the lowest-numbered segment */
1750 1.214 ad return lfs_rewind(fs, *(int *)ap->a_data);
1751 1.148 perseant
1752 1.148 perseant case LFCNINVAL:
1753 1.214 ad /* Mark a segment SEGUSE_INVAL */
1754 1.214 ad LFS_SEGENTRY(sup, fs, *(int *)ap->a_data, bp);
1755 1.214 ad if (sup->su_nbytes > 0) {
1756 1.214 ad brelse(bp, 0);
1757 1.214 ad lfs_unset_inval_all(fs);
1758 1.214 ad return EBUSY;
1759 1.214 ad }
1760 1.214 ad sup->su_flags |= SEGUSE_INVAL;
1761 1.236 hannken VOP_BWRITE(bp->b_vp, bp);
1762 1.214 ad return 0;
1763 1.148 perseant
1764 1.148 perseant case LFCNRESIZE:
1765 1.214 ad /* Resize the filesystem */
1766 1.214 ad return lfs_resize_fs(fs, *(int *)ap->a_data);
1767 1.148 perseant
1768 1.168 perseant case LFCNWRAPSTOP:
1769 1.179 perseant case LFCNWRAPSTOP_COMPAT:
1770 1.214 ad /*
1771 1.214 ad * Hold lfs_newseg at segment 0; if requested, sleep until
1772 1.214 ad * the filesystem wraps around. To support external agents
1773 1.214 ad * (dump, fsck-based regression test) that need to look at
1774 1.214 ad * a snapshot of the filesystem, without necessarily
1775 1.214 ad * requiring that all fs activity stops.
1776 1.214 ad */
1777 1.214 ad if (fs->lfs_stoplwp == curlwp)
1778 1.214 ad return EALREADY;
1779 1.214 ad
1780 1.214 ad mutex_enter(&lfs_lock);
1781 1.214 ad while (fs->lfs_stoplwp != NULL)
1782 1.214 ad cv_wait(&fs->lfs_stopcv, &lfs_lock);
1783 1.214 ad fs->lfs_stoplwp = curlwp;
1784 1.214 ad if (fs->lfs_nowrap == 0)
1785 1.214 ad log(LOG_NOTICE, "%s: disabled log wrap\n", fs->lfs_fsmnt);
1786 1.214 ad ++fs->lfs_nowrap;
1787 1.222 christos if (*(int *)ap->a_data == 1
1788 1.224 pooka || ap->a_command == LFCNWRAPSTOP_COMPAT) {
1789 1.214 ad log(LOG_NOTICE, "LFCNSTOPWRAP waiting for log wrap\n");
1790 1.214 ad error = mtsleep(&fs->lfs_nowrap, PCATCH | PUSER,
1791 1.214 ad "segwrap", 0, &lfs_lock);
1792 1.214 ad log(LOG_NOTICE, "LFCNSTOPWRAP done waiting\n");
1793 1.214 ad if (error) {
1794 1.214 ad lfs_wrapgo(fs, VTOI(ap->a_vp), 0);
1795 1.214 ad }
1796 1.214 ad }
1797 1.214 ad mutex_exit(&lfs_lock);
1798 1.214 ad return 0;
1799 1.168 perseant
1800 1.168 perseant case LFCNWRAPGO:
1801 1.179 perseant case LFCNWRAPGO_COMPAT:
1802 1.214 ad /*
1803 1.214 ad * Having done its work, the agent wakes up the writer.
1804 1.214 ad * If the argument is 1, it sleeps until a new segment
1805 1.214 ad * is selected.
1806 1.214 ad */
1807 1.214 ad mutex_enter(&lfs_lock);
1808 1.214 ad error = lfs_wrapgo(fs, VTOI(ap->a_vp),
1809 1.222 christos ap->a_command == LFCNWRAPGO_COMPAT ? 1 :
1810 1.222 christos *((int *)ap->a_data));
1811 1.214 ad mutex_exit(&lfs_lock);
1812 1.214 ad return error;
1813 1.168 perseant
1814 1.188 perseant case LFCNWRAPPASS:
1815 1.214 ad if ((VTOI(ap->a_vp)->i_lfs_iflags & LFSI_WRAPWAIT))
1816 1.214 ad return EALREADY;
1817 1.214 ad mutex_enter(&lfs_lock);
1818 1.214 ad if (fs->lfs_stoplwp != curlwp) {
1819 1.214 ad mutex_exit(&lfs_lock);
1820 1.214 ad return EALREADY;
1821 1.214 ad }
1822 1.214 ad if (fs->lfs_nowrap == 0) {
1823 1.214 ad mutex_exit(&lfs_lock);
1824 1.214 ad return EBUSY;
1825 1.214 ad }
1826 1.214 ad fs->lfs_wrappass = 1;
1827 1.214 ad wakeup(&fs->lfs_wrappass);
1828 1.214 ad /* Wait for the log to wrap, if asked */
1829 1.214 ad if (*(int *)ap->a_data) {
1830 1.235 rmind mutex_enter(ap->a_vp->v_interlock);
1831 1.239 perseant if (lfs_vref(ap->a_vp) != 0)
1832 1.239 perseant panic("LFCNWRAPPASS: lfs_vref failed");
1833 1.214 ad VTOI(ap->a_vp)->i_lfs_iflags |= LFSI_WRAPWAIT;
1834 1.214 ad log(LOG_NOTICE, "LFCNPASS waiting for log wrap\n");
1835 1.214 ad error = mtsleep(&fs->lfs_nowrap, PCATCH | PUSER,
1836 1.214 ad "segwrap", 0, &lfs_lock);
1837 1.214 ad log(LOG_NOTICE, "LFCNPASS done waiting\n");
1838 1.214 ad VTOI(ap->a_vp)->i_lfs_iflags &= ~LFSI_WRAPWAIT;
1839 1.214 ad lfs_vunref(ap->a_vp);
1840 1.214 ad }
1841 1.214 ad mutex_exit(&lfs_lock);
1842 1.214 ad return error;
1843 1.188 perseant
1844 1.188 perseant case LFCNWRAPSTATUS:
1845 1.214 ad mutex_enter(&lfs_lock);
1846 1.214 ad *(int *)ap->a_data = fs->lfs_wrapstatus;
1847 1.214 ad mutex_exit(&lfs_lock);
1848 1.214 ad return 0;
1849 1.188 perseant
1850 1.89 perseant default:
1851 1.245 dholland return ulfs_fcntl(v);
1852 1.89 perseant }
1853 1.89 perseant return 0;
1854 1.60 chs }
1855 1.60 chs
1856 1.84 perseant /*
1857 1.84 perseant * Return the last logical file offset that should be written for this file
1858 1.86 perseant * if we're doing a write that ends at "size". If writing, we need to know
1859 1.84 perseant * about sizes on disk, i.e. fragments if there are any; if reading, we need
1860 1.84 perseant * to know about entire blocks.
1861 1.84 perseant */
1862 1.84 perseant void
1863 1.84 perseant lfs_gop_size(struct vnode *vp, off_t size, off_t *eobp, int flags)
1864 1.84 perseant {
1865 1.84 perseant struct inode *ip = VTOI(vp);
1866 1.135 perry struct lfs *fs = ip->i_lfs;
1867 1.84 perseant daddr_t olbn, nlbn;
1868 1.84 perseant
1869 1.248 christos olbn = lfs_lblkno(fs, ip->i_size);
1870 1.248 christos nlbn = lfs_lblkno(fs, size);
1871 1.245 dholland if (!(flags & GOP_SIZE_MEM) && nlbn < ULFS_NDADDR && olbn <= nlbn) {
1872 1.248 christos *eobp = lfs_fragroundup(fs, size);
1873 1.86 perseant } else {
1874 1.248 christos *eobp = lfs_blkroundup(fs, size);
1875 1.86 perseant }
1876 1.84 perseant }
1877 1.84 perseant
1878 1.84 perseant #ifdef DEBUG
1879 1.84 perseant void lfs_dump_vop(void *);
1880 1.84 perseant
1881 1.84 perseant void
1882 1.84 perseant lfs_dump_vop(void *v)
1883 1.84 perseant {
1884 1.86 perseant struct vop_putpages_args /* {
1885 1.86 perseant struct vnode *a_vp;
1886 1.86 perseant voff_t a_offlo;
1887 1.86 perseant voff_t a_offhi;
1888 1.86 perseant int a_flags;
1889 1.86 perseant } */ *ap = v;
1890 1.84 perseant
1891 1.106 ragge #ifdef DDB
1892 1.84 perseant vfs_vnode_print(ap->a_vp, 0, printf);
1893 1.106 ragge #endif
1894 1.102 fvdl lfs_dump_dinode(VTOI(ap->a_vp)->i_din.ffs1_din);
1895 1.84 perseant }
1896 1.84 perseant #endif
1897 1.84 perseant
1898 1.84 perseant int
1899 1.84 perseant lfs_mmap(void *v)
1900 1.84 perseant {
1901 1.84 perseant struct vop_mmap_args /* {
1902 1.86 perseant const struct vnodeop_desc *a_desc;
1903 1.86 perseant struct vnode *a_vp;
1904 1.209 pooka vm_prot_t a_prot;
1905 1.176 elad kauth_cred_t a_cred;
1906 1.84 perseant } */ *ap = v;
1907 1.84 perseant
1908 1.84 perseant if (VTOI(ap->a_vp)->i_number == LFS_IFILE_INUM)
1909 1.84 perseant return EOPNOTSUPP;
1910 1.245 dholland return ulfs_mmap(v);
1911 1.84 perseant }
1912 1.254 dholland
1913 1.254 dholland static int
1914 1.254 dholland lfs_openextattr(void *v)
1915 1.254 dholland {
1916 1.254 dholland struct vop_openextattr_args /* {
1917 1.254 dholland struct vnode *a_vp;
1918 1.254 dholland kauth_cred_t a_cred;
1919 1.254 dholland struct proc *a_p;
1920 1.254 dholland } */ *ap = v;
1921 1.254 dholland struct inode *ip = VTOI(ap->a_vp);
1922 1.254 dholland struct ulfsmount *ump = ip->i_ump;
1923 1.254 dholland //struct lfs *fs = ip->i_lfs;
1924 1.254 dholland
1925 1.254 dholland /* Not supported for ULFS1 file systems. */
1926 1.254 dholland if (ump->um_fstype == ULFS1)
1927 1.254 dholland return (EOPNOTSUPP);
1928 1.254 dholland
1929 1.254 dholland /* XXX Not implemented for ULFS2 file systems. */
1930 1.254 dholland return (EOPNOTSUPP);
1931 1.254 dholland }
1932 1.254 dholland
1933 1.254 dholland static int
1934 1.254 dholland lfs_closeextattr(void *v)
1935 1.254 dholland {
1936 1.254 dholland struct vop_closeextattr_args /* {
1937 1.254 dholland struct vnode *a_vp;
1938 1.254 dholland int a_commit;
1939 1.254 dholland kauth_cred_t a_cred;
1940 1.254 dholland struct proc *a_p;
1941 1.254 dholland } */ *ap = v;
1942 1.254 dholland struct inode *ip = VTOI(ap->a_vp);
1943 1.254 dholland struct ulfsmount *ump = ip->i_ump;
1944 1.254 dholland //struct lfs *fs = ip->i_lfs;
1945 1.254 dholland
1946 1.254 dholland /* Not supported for ULFS1 file systems. */
1947 1.254 dholland if (ump->um_fstype == ULFS1)
1948 1.254 dholland return (EOPNOTSUPP);
1949 1.254 dholland
1950 1.254 dholland /* XXX Not implemented for ULFS2 file systems. */
1951 1.254 dholland return (EOPNOTSUPP);
1952 1.254 dholland }
1953 1.254 dholland
1954 1.254 dholland static int
1955 1.254 dholland lfs_getextattr(void *v)
1956 1.254 dholland {
1957 1.254 dholland struct vop_getextattr_args /* {
1958 1.254 dholland struct vnode *a_vp;
1959 1.254 dholland int a_attrnamespace;
1960 1.254 dholland const char *a_name;
1961 1.254 dholland struct uio *a_uio;
1962 1.254 dholland size_t *a_size;
1963 1.254 dholland kauth_cred_t a_cred;
1964 1.254 dholland struct proc *a_p;
1965 1.254 dholland } */ *ap = v;
1966 1.254 dholland struct vnode *vp = ap->a_vp;
1967 1.254 dholland struct inode *ip = VTOI(vp);
1968 1.254 dholland struct ulfsmount *ump = ip->i_ump;
1969 1.254 dholland //struct lfs *fs = ip->i_lfs;
1970 1.254 dholland int error;
1971 1.254 dholland
1972 1.254 dholland if (ump->um_fstype == ULFS1) {
1973 1.254 dholland #ifdef LFS_EXTATTR
1974 1.254 dholland fstrans_start(vp->v_mount, FSTRANS_SHARED);
1975 1.254 dholland error = ulfs_getextattr(ap);
1976 1.254 dholland fstrans_done(vp->v_mount);
1977 1.254 dholland #else
1978 1.254 dholland error = EOPNOTSUPP;
1979 1.254 dholland #endif
1980 1.254 dholland return error;
1981 1.254 dholland }
1982 1.254 dholland
1983 1.254 dholland /* XXX Not implemented for ULFS2 file systems. */
1984 1.254 dholland return (EOPNOTSUPP);
1985 1.254 dholland }
1986 1.254 dholland
1987 1.254 dholland static int
1988 1.254 dholland lfs_setextattr(void *v)
1989 1.254 dholland {
1990 1.254 dholland struct vop_setextattr_args /* {
1991 1.254 dholland struct vnode *a_vp;
1992 1.254 dholland int a_attrnamespace;
1993 1.254 dholland const char *a_name;
1994 1.254 dholland struct uio *a_uio;
1995 1.254 dholland kauth_cred_t a_cred;
1996 1.254 dholland struct proc *a_p;
1997 1.254 dholland } */ *ap = v;
1998 1.254 dholland struct vnode *vp = ap->a_vp;
1999 1.254 dholland struct inode *ip = VTOI(vp);
2000 1.254 dholland struct ulfsmount *ump = ip->i_ump;
2001 1.254 dholland //struct lfs *fs = ip->i_lfs;
2002 1.254 dholland int error;
2003 1.254 dholland
2004 1.254 dholland if (ump->um_fstype == ULFS1) {
2005 1.254 dholland #ifdef LFS_EXTATTR
2006 1.254 dholland fstrans_start(vp->v_mount, FSTRANS_SHARED);
2007 1.254 dholland error = ulfs_setextattr(ap);
2008 1.254 dholland fstrans_done(vp->v_mount);
2009 1.254 dholland #else
2010 1.254 dholland error = EOPNOTSUPP;
2011 1.254 dholland #endif
2012 1.254 dholland return error;
2013 1.254 dholland }
2014 1.254 dholland
2015 1.254 dholland /* XXX Not implemented for ULFS2 file systems. */
2016 1.254 dholland return (EOPNOTSUPP);
2017 1.254 dholland }
2018 1.254 dholland
2019 1.254 dholland static int
2020 1.254 dholland lfs_listextattr(void *v)
2021 1.254 dholland {
2022 1.254 dholland struct vop_listextattr_args /* {
2023 1.254 dholland struct vnode *a_vp;
2024 1.254 dholland int a_attrnamespace;
2025 1.254 dholland struct uio *a_uio;
2026 1.254 dholland size_t *a_size;
2027 1.254 dholland kauth_cred_t a_cred;
2028 1.254 dholland struct proc *a_p;
2029 1.254 dholland } */ *ap = v;
2030 1.254 dholland struct vnode *vp = ap->a_vp;
2031 1.254 dholland struct inode *ip = VTOI(vp);
2032 1.254 dholland struct ulfsmount *ump = ip->i_ump;
2033 1.254 dholland //struct lfs *fs = ip->i_lfs;
2034 1.254 dholland int error;
2035 1.254 dholland
2036 1.254 dholland if (ump->um_fstype == ULFS1) {
2037 1.254 dholland #ifdef LFS_EXTATTR
2038 1.254 dholland fstrans_start(vp->v_mount, FSTRANS_SHARED);
2039 1.254 dholland error = ulfs_listextattr(ap);
2040 1.254 dholland fstrans_done(vp->v_mount);
2041 1.254 dholland #else
2042 1.254 dholland error = EOPNOTSUPP;
2043 1.254 dholland #endif
2044 1.254 dholland return error;
2045 1.254 dholland }
2046 1.254 dholland
2047 1.254 dholland /* XXX Not implemented for ULFS2 file systems. */
2048 1.254 dholland return (EOPNOTSUPP);
2049 1.254 dholland }
2050 1.254 dholland
2051 1.254 dholland static int
2052 1.254 dholland lfs_deleteextattr(void *v)
2053 1.254 dholland {
2054 1.254 dholland struct vop_deleteextattr_args /* {
2055 1.254 dholland struct vnode *a_vp;
2056 1.254 dholland int a_attrnamespace;
2057 1.254 dholland kauth_cred_t a_cred;
2058 1.254 dholland struct proc *a_p;
2059 1.254 dholland } */ *ap = v;
2060 1.254 dholland struct vnode *vp = ap->a_vp;
2061 1.254 dholland struct inode *ip = VTOI(vp);
2062 1.254 dholland struct ulfsmount *ump = ip->i_ump;
2063 1.254 dholland //struct fs *fs = ip->i_lfs;
2064 1.254 dholland int error;
2065 1.254 dholland
2066 1.254 dholland if (ump->um_fstype == ULFS1) {
2067 1.254 dholland #ifdef LFS_EXTATTR
2068 1.254 dholland fstrans_start(vp->v_mount, FSTRANS_SHARED);
2069 1.254 dholland error = ulfs_deleteextattr(ap);
2070 1.254 dholland fstrans_done(vp->v_mount);
2071 1.254 dholland #else
2072 1.254 dholland error = EOPNOTSUPP;
2073 1.254 dholland #endif
2074 1.254 dholland return error;
2075 1.254 dholland }
2076 1.254 dholland
2077 1.254 dholland /* XXX Not implemented for ULFS2 file systems. */
2078 1.254 dholland return (EOPNOTSUPP);
2079 1.254 dholland }
2080