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