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