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