udf_allocation.c revision 1.1.2.5 1 1.1.2.5 yamt /* $NetBSD: udf_allocation.c,v 1.1.2.5 2009/07/18 14:53:22 yamt Exp $ */
2 1.1.2.2 yamt
3 1.1.2.2 yamt /*
4 1.1.2.2 yamt * Copyright (c) 2006, 2008 Reinoud Zandijk
5 1.1.2.2 yamt * All rights reserved.
6 1.1.2.2 yamt *
7 1.1.2.2 yamt * Redistribution and use in source and binary forms, with or without
8 1.1.2.2 yamt * modification, are permitted provided that the following conditions
9 1.1.2.2 yamt * are met:
10 1.1.2.2 yamt * 1. Redistributions of source code must retain the above copyright
11 1.1.2.2 yamt * notice, this list of conditions and the following disclaimer.
12 1.1.2.2 yamt * 2. Redistributions in binary form must reproduce the above copyright
13 1.1.2.2 yamt * notice, this list of conditions and the following disclaimer in the
14 1.1.2.2 yamt * documentation and/or other materials provided with the distribution.
15 1.1.2.2 yamt *
16 1.1.2.2 yamt * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
17 1.1.2.2 yamt * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
18 1.1.2.2 yamt * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
19 1.1.2.2 yamt * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
20 1.1.2.2 yamt * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
21 1.1.2.2 yamt * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
22 1.1.2.2 yamt * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
23 1.1.2.2 yamt * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24 1.1.2.2 yamt * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
25 1.1.2.2 yamt * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 1.1.2.2 yamt *
27 1.1.2.2 yamt */
28 1.1.2.2 yamt
29 1.1.2.2 yamt #include <sys/cdefs.h>
30 1.1.2.2 yamt #ifndef lint
31 1.1.2.5 yamt __KERNEL_RCSID(0, "$NetBSD: udf_allocation.c,v 1.1.2.5 2009/07/18 14:53:22 yamt Exp $");
32 1.1.2.2 yamt #endif /* not lint */
33 1.1.2.2 yamt
34 1.1.2.2 yamt
35 1.1.2.2 yamt #if defined(_KERNEL_OPT)
36 1.1.2.2 yamt #include "opt_compat_netbsd.h"
37 1.1.2.2 yamt #endif
38 1.1.2.2 yamt
39 1.1.2.2 yamt /* TODO strip */
40 1.1.2.2 yamt #include <sys/param.h>
41 1.1.2.2 yamt #include <sys/systm.h>
42 1.1.2.2 yamt #include <sys/sysctl.h>
43 1.1.2.2 yamt #include <sys/namei.h>
44 1.1.2.2 yamt #include <sys/proc.h>
45 1.1.2.2 yamt #include <sys/kernel.h>
46 1.1.2.2 yamt #include <sys/vnode.h>
47 1.1.2.2 yamt #include <miscfs/genfs/genfs_node.h>
48 1.1.2.2 yamt #include <sys/mount.h>
49 1.1.2.2 yamt #include <sys/buf.h>
50 1.1.2.2 yamt #include <sys/file.h>
51 1.1.2.2 yamt #include <sys/device.h>
52 1.1.2.2 yamt #include <sys/disklabel.h>
53 1.1.2.2 yamt #include <sys/ioctl.h>
54 1.1.2.2 yamt #include <sys/malloc.h>
55 1.1.2.2 yamt #include <sys/dirent.h>
56 1.1.2.2 yamt #include <sys/stat.h>
57 1.1.2.2 yamt #include <sys/conf.h>
58 1.1.2.2 yamt #include <sys/kauth.h>
59 1.1.2.2 yamt #include <sys/kthread.h>
60 1.1.2.2 yamt #include <dev/clock_subr.h>
61 1.1.2.2 yamt
62 1.1.2.2 yamt #include <fs/udf/ecma167-udf.h>
63 1.1.2.2 yamt #include <fs/udf/udf_mount.h>
64 1.1.2.2 yamt
65 1.1.2.2 yamt #include "udf.h"
66 1.1.2.2 yamt #include "udf_subr.h"
67 1.1.2.2 yamt #include "udf_bswap.h"
68 1.1.2.2 yamt
69 1.1.2.2 yamt
70 1.1.2.2 yamt #define VTOI(vnode) ((struct udf_node *) vnode->v_data)
71 1.1.2.2 yamt
72 1.1.2.2 yamt static void udf_record_allocation_in_node(struct udf_mount *ump,
73 1.1.2.2 yamt struct buf *buf, uint16_t vpart_num, uint64_t *mapping,
74 1.1.2.2 yamt struct long_ad *node_ad_cpy);
75 1.1.2.2 yamt
76 1.1.2.2 yamt /*
77 1.1.2.2 yamt * IDEA/BUSY: Each udf_node gets its own extentwalker state for all operations;
78 1.1.2.2 yamt * this will hopefully/likely reduce O(nlog(n)) to O(1) for most functionality
79 1.1.2.2 yamt * since actions are most likely sequencial and thus seeking doesn't need
80 1.1.2.2 yamt * searching for the same or adjacent position again.
81 1.1.2.2 yamt */
82 1.1.2.2 yamt
83 1.1.2.2 yamt /* --------------------------------------------------------------------- */
84 1.1.2.3 yamt
85 1.1.2.3 yamt #if 0
86 1.1.2.2 yamt #if 1
87 1.1.2.2 yamt static void
88 1.1.2.2 yamt udf_node_dump(struct udf_node *udf_node) {
89 1.1.2.2 yamt struct file_entry *fe;
90 1.1.2.2 yamt struct extfile_entry *efe;
91 1.1.2.2 yamt struct icb_tag *icbtag;
92 1.1.2.3 yamt struct long_ad s_ad;
93 1.1.2.2 yamt uint64_t inflen;
94 1.1.2.3 yamt uint32_t icbflags, addr_type;
95 1.1.2.2 yamt uint32_t len, lb_num;
96 1.1.2.3 yamt uint32_t flags;
97 1.1.2.2 yamt int part_num;
98 1.1.2.3 yamt int lb_size, eof, slot;
99 1.1.2.2 yamt
100 1.1.2.3 yamt if ((udf_verbose & UDF_DEBUG_NODEDUMP) == 0)
101 1.1.2.2 yamt return;
102 1.1.2.2 yamt
103 1.1.2.2 yamt lb_size = udf_rw32(udf_node->ump->logical_vol->lb_size);
104 1.1.2.2 yamt
105 1.1.2.2 yamt fe = udf_node->fe;
106 1.1.2.2 yamt efe = udf_node->efe;
107 1.1.2.2 yamt if (fe) {
108 1.1.2.2 yamt icbtag = &fe->icbtag;
109 1.1.2.2 yamt inflen = udf_rw64(fe->inf_len);
110 1.1.2.2 yamt } else {
111 1.1.2.2 yamt icbtag = &efe->icbtag;
112 1.1.2.2 yamt inflen = udf_rw64(efe->inf_len);
113 1.1.2.2 yamt }
114 1.1.2.2 yamt
115 1.1.2.2 yamt icbflags = udf_rw16(icbtag->flags);
116 1.1.2.2 yamt addr_type = icbflags & UDF_ICB_TAG_FLAGS_ALLOC_MASK;
117 1.1.2.2 yamt
118 1.1.2.3 yamt printf("udf_node_dump %p :\n", udf_node);
119 1.1.2.2 yamt
120 1.1.2.2 yamt if (addr_type == UDF_ICB_INTERN_ALLOC) {
121 1.1.2.3 yamt printf("\tIntern alloc, len = %"PRIu64"\n", inflen);
122 1.1.2.2 yamt return;
123 1.1.2.2 yamt }
124 1.1.2.2 yamt
125 1.1.2.3 yamt printf("\tInflen = %"PRIu64"\n", inflen);
126 1.1.2.3 yamt printf("\t\t");
127 1.1.2.2 yamt
128 1.1.2.3 yamt slot = 0;
129 1.1.2.3 yamt for (;;) {
130 1.1.2.3 yamt udf_get_adslot(udf_node, slot, &s_ad, &eof);
131 1.1.2.3 yamt if (eof)
132 1.1.2.3 yamt break;
133 1.1.2.3 yamt part_num = udf_rw16(s_ad.loc.part_num);
134 1.1.2.3 yamt lb_num = udf_rw32(s_ad.loc.lb_num);
135 1.1.2.3 yamt len = udf_rw32(s_ad.len);
136 1.1.2.3 yamt flags = UDF_EXT_FLAGS(len);
137 1.1.2.3 yamt len = UDF_EXT_LEN(len);
138 1.1.2.2 yamt
139 1.1.2.2 yamt printf("[");
140 1.1.2.2 yamt if (part_num >= 0)
141 1.1.2.2 yamt printf("part %d, ", part_num);
142 1.1.2.2 yamt printf("lb_num %d, len %d", lb_num, len);
143 1.1.2.2 yamt if (flags)
144 1.1.2.3 yamt printf(", flags %d", flags>>30);
145 1.1.2.2 yamt printf("] ");
146 1.1.2.3 yamt
147 1.1.2.3 yamt if (flags == UDF_EXT_REDIRECT) {
148 1.1.2.3 yamt printf("\n\textent END\n\tallocation extent\n\t\t");
149 1.1.2.3 yamt }
150 1.1.2.3 yamt
151 1.1.2.3 yamt slot++;
152 1.1.2.2 yamt }
153 1.1.2.3 yamt printf("\n\tl_ad END\n\n");
154 1.1.2.2 yamt }
155 1.1.2.2 yamt #else
156 1.1.2.2 yamt #define udf_node_dump(a)
157 1.1.2.2 yamt #endif
158 1.1.2.2 yamt
159 1.1.2.3 yamt
160 1.1.2.3 yamt static void
161 1.1.2.3 yamt udf_assert_allocated(struct udf_mount *ump, uint16_t vpart_num,
162 1.1.2.3 yamt uint32_t lb_num, uint32_t num_lb)
163 1.1.2.3 yamt {
164 1.1.2.3 yamt struct udf_bitmap *bitmap;
165 1.1.2.3 yamt struct part_desc *pdesc;
166 1.1.2.3 yamt uint32_t ptov;
167 1.1.2.3 yamt uint32_t bitval;
168 1.1.2.3 yamt uint8_t *bpos;
169 1.1.2.3 yamt int bit;
170 1.1.2.3 yamt int phys_part;
171 1.1.2.3 yamt int ok;
172 1.1.2.3 yamt
173 1.1.2.3 yamt DPRINTF(PARANOIA, ("udf_assert_allocated: check virt lbnum %d "
174 1.1.2.3 yamt "part %d + %d sect\n", lb_num, vpart_num, num_lb));
175 1.1.2.3 yamt
176 1.1.2.3 yamt /* get partition backing up this vpart_num */
177 1.1.2.3 yamt pdesc = ump->partitions[ump->vtop[vpart_num]];
178 1.1.2.3 yamt
179 1.1.2.3 yamt switch (ump->vtop_tp[vpart_num]) {
180 1.1.2.3 yamt case UDF_VTOP_TYPE_PHYS :
181 1.1.2.3 yamt case UDF_VTOP_TYPE_SPARABLE :
182 1.1.2.3 yamt /* free space to freed or unallocated space bitmap */
183 1.1.2.3 yamt ptov = udf_rw32(pdesc->start_loc);
184 1.1.2.3 yamt phys_part = ump->vtop[vpart_num];
185 1.1.2.3 yamt
186 1.1.2.3 yamt /* use unallocated bitmap */
187 1.1.2.3 yamt bitmap = &ump->part_unalloc_bits[phys_part];
188 1.1.2.3 yamt
189 1.1.2.3 yamt /* if no bitmaps are defined, bail out */
190 1.1.2.3 yamt if (bitmap->bits == NULL)
191 1.1.2.3 yamt break;
192 1.1.2.3 yamt
193 1.1.2.3 yamt /* check bits */
194 1.1.2.3 yamt KASSERT(bitmap->bits);
195 1.1.2.3 yamt ok = 1;
196 1.1.2.3 yamt bpos = bitmap->bits + lb_num/8;
197 1.1.2.3 yamt bit = lb_num % 8;
198 1.1.2.3 yamt while (num_lb > 0) {
199 1.1.2.3 yamt bitval = (1 << bit);
200 1.1.2.3 yamt DPRINTF(PARANOIA, ("XXX : check %d, %p, bit %d\n",
201 1.1.2.3 yamt lb_num, bpos, bit));
202 1.1.2.3 yamt KASSERT(bitmap->bits + lb_num/8 == bpos);
203 1.1.2.3 yamt if (*bpos & bitval) {
204 1.1.2.3 yamt printf("\tlb_num %d is NOT marked busy\n",
205 1.1.2.3 yamt lb_num);
206 1.1.2.3 yamt ok = 0;
207 1.1.2.3 yamt }
208 1.1.2.3 yamt lb_num++; num_lb--;
209 1.1.2.3 yamt bit = (bit + 1) % 8;
210 1.1.2.3 yamt if (bit == 0)
211 1.1.2.3 yamt bpos++;
212 1.1.2.3 yamt }
213 1.1.2.3 yamt if (!ok) {
214 1.1.2.3 yamt /* KASSERT(0); */
215 1.1.2.3 yamt }
216 1.1.2.3 yamt
217 1.1.2.3 yamt break;
218 1.1.2.3 yamt case UDF_VTOP_TYPE_VIRT :
219 1.1.2.3 yamt /* TODO check space */
220 1.1.2.3 yamt KASSERT(num_lb == 1);
221 1.1.2.3 yamt break;
222 1.1.2.3 yamt case UDF_VTOP_TYPE_META :
223 1.1.2.3 yamt /* TODO check space in the metadata bitmap */
224 1.1.2.3 yamt default:
225 1.1.2.3 yamt /* not implemented */
226 1.1.2.3 yamt break;
227 1.1.2.3 yamt }
228 1.1.2.3 yamt }
229 1.1.2.3 yamt
230 1.1.2.3 yamt
231 1.1.2.2 yamt static void
232 1.1.2.2 yamt udf_node_sanity_check(struct udf_node *udf_node,
233 1.1.2.3 yamt uint64_t *cnt_inflen, uint64_t *cnt_logblksrec)
234 1.1.2.3 yamt {
235 1.1.2.3 yamt union dscrptr *dscr;
236 1.1.2.2 yamt struct file_entry *fe;
237 1.1.2.2 yamt struct extfile_entry *efe;
238 1.1.2.2 yamt struct icb_tag *icbtag;
239 1.1.2.3 yamt struct long_ad s_ad;
240 1.1.2.2 yamt uint64_t inflen, logblksrec;
241 1.1.2.3 yamt uint32_t icbflags, addr_type;
242 1.1.2.3 yamt uint32_t len, lb_num, l_ea, l_ad, max_l_ad;
243 1.1.2.3 yamt uint16_t part_num;
244 1.1.2.3 yamt uint8_t *data_pos;
245 1.1.2.3 yamt int dscr_size, lb_size, flags, whole_lb;
246 1.1.2.3 yamt int i, slot, eof;
247 1.1.2.3 yamt
248 1.1.2.3 yamt // KASSERT(mutex_owned(&udf_node->ump->allocate_mutex));
249 1.1.2.2 yamt
250 1.1.2.3 yamt if (1)
251 1.1.2.3 yamt udf_node_dump(udf_node);
252 1.1.2.2 yamt
253 1.1.2.2 yamt lb_size = udf_rw32(udf_node->ump->logical_vol->lb_size);
254 1.1.2.2 yamt
255 1.1.2.2 yamt fe = udf_node->fe;
256 1.1.2.2 yamt efe = udf_node->efe;
257 1.1.2.2 yamt if (fe) {
258 1.1.2.3 yamt dscr = (union dscrptr *) fe;
259 1.1.2.3 yamt icbtag = &fe->icbtag;
260 1.1.2.3 yamt inflen = udf_rw64(fe->inf_len);
261 1.1.2.2 yamt dscr_size = sizeof(struct file_entry) -1;
262 1.1.2.3 yamt logblksrec = udf_rw64(fe->logblks_rec);
263 1.1.2.2 yamt l_ad = udf_rw32(fe->l_ad);
264 1.1.2.3 yamt l_ea = udf_rw32(fe->l_ea);
265 1.1.2.2 yamt } else {
266 1.1.2.3 yamt dscr = (union dscrptr *) efe;
267 1.1.2.3 yamt icbtag = &efe->icbtag;
268 1.1.2.3 yamt inflen = udf_rw64(efe->inf_len);
269 1.1.2.2 yamt dscr_size = sizeof(struct extfile_entry) -1;
270 1.1.2.3 yamt logblksrec = udf_rw64(efe->logblks_rec);
271 1.1.2.2 yamt l_ad = udf_rw32(efe->l_ad);
272 1.1.2.3 yamt l_ea = udf_rw32(efe->l_ea);
273 1.1.2.2 yamt }
274 1.1.2.3 yamt data_pos = (uint8_t *) dscr + dscr_size + l_ea;
275 1.1.2.3 yamt max_l_ad = lb_size - dscr_size - l_ea;
276 1.1.2.2 yamt icbflags = udf_rw16(icbtag->flags);
277 1.1.2.2 yamt addr_type = icbflags & UDF_ICB_TAG_FLAGS_ALLOC_MASK;
278 1.1.2.2 yamt
279 1.1.2.3 yamt /* check if tail is zero */
280 1.1.2.3 yamt DPRINTF(PARANOIA, ("Sanity check blank tail\n"));
281 1.1.2.3 yamt for (i = l_ad; i < max_l_ad; i++) {
282 1.1.2.3 yamt if (data_pos[i] != 0)
283 1.1.2.3 yamt printf( "sanity_check: violation: node byte %d "
284 1.1.2.3 yamt "has value %d\n", i, data_pos[i]);
285 1.1.2.3 yamt }
286 1.1.2.3 yamt
287 1.1.2.2 yamt /* reset counters */
288 1.1.2.2 yamt *cnt_inflen = 0;
289 1.1.2.2 yamt *cnt_logblksrec = 0;
290 1.1.2.2 yamt
291 1.1.2.2 yamt if (addr_type == UDF_ICB_INTERN_ALLOC) {
292 1.1.2.2 yamt KASSERT(l_ad <= max_l_ad);
293 1.1.2.2 yamt KASSERT(l_ad == inflen);
294 1.1.2.2 yamt *cnt_inflen = inflen;
295 1.1.2.2 yamt return;
296 1.1.2.2 yamt }
297 1.1.2.2 yamt
298 1.1.2.2 yamt /* start counting */
299 1.1.2.2 yamt whole_lb = 1;
300 1.1.2.3 yamt slot = 0;
301 1.1.2.3 yamt for (;;) {
302 1.1.2.3 yamt udf_get_adslot(udf_node, slot, &s_ad, &eof);
303 1.1.2.3 yamt if (eof)
304 1.1.2.3 yamt break;
305 1.1.2.2 yamt KASSERT(whole_lb == 1);
306 1.1.2.3 yamt
307 1.1.2.3 yamt part_num = udf_rw16(s_ad.loc.part_num);
308 1.1.2.3 yamt lb_num = udf_rw32(s_ad.loc.lb_num);
309 1.1.2.3 yamt len = udf_rw32(s_ad.len);
310 1.1.2.3 yamt flags = UDF_EXT_FLAGS(len);
311 1.1.2.3 yamt len = UDF_EXT_LEN(len);
312 1.1.2.3 yamt
313 1.1.2.3 yamt if (flags != UDF_EXT_REDIRECT) {
314 1.1.2.3 yamt *cnt_inflen += len;
315 1.1.2.3 yamt if (flags == UDF_EXT_ALLOCATED) {
316 1.1.2.3 yamt *cnt_logblksrec += (len + lb_size -1) / lb_size;
317 1.1.2.3 yamt }
318 1.1.2.2 yamt } else {
319 1.1.2.3 yamt KASSERT(len == lb_size);
320 1.1.2.2 yamt }
321 1.1.2.3 yamt /* check allocation */
322 1.1.2.3 yamt if (flags == UDF_EXT_ALLOCATED)
323 1.1.2.3 yamt udf_assert_allocated(udf_node->ump, part_num, lb_num,
324 1.1.2.3 yamt (len + lb_size - 1) / lb_size);
325 1.1.2.3 yamt
326 1.1.2.3 yamt /* check whole lb */
327 1.1.2.2 yamt whole_lb = ((len % lb_size) == 0);
328 1.1.2.3 yamt
329 1.1.2.3 yamt slot++;
330 1.1.2.2 yamt }
331 1.1.2.2 yamt /* rest should be zero (ad_off > l_ad < max_l_ad - adlen) */
332 1.1.2.2 yamt
333 1.1.2.2 yamt KASSERT(*cnt_inflen == inflen);
334 1.1.2.2 yamt KASSERT(*cnt_logblksrec == logblksrec);
335 1.1.2.2 yamt
336 1.1.2.3 yamt // KASSERT(mutex_owned(&udf_node->ump->allocate_mutex));
337 1.1.2.2 yamt }
338 1.1.2.2 yamt #else
339 1.1.2.3 yamt static void
340 1.1.2.3 yamt udf_node_sanity_check(struct udf_node *udf_node,
341 1.1.2.3 yamt uint64_t *cnt_inflen, uint64_t *cnt_logblksrec) {
342 1.1.2.3 yamt struct file_entry *fe;
343 1.1.2.3 yamt struct extfile_entry *efe;
344 1.1.2.3 yamt struct icb_tag *icbtag;
345 1.1.2.3 yamt uint64_t inflen, logblksrec;
346 1.1.2.3 yamt int dscr_size, lb_size;
347 1.1.2.3 yamt
348 1.1.2.3 yamt lb_size = udf_rw32(udf_node->ump->logical_vol->lb_size);
349 1.1.2.3 yamt
350 1.1.2.3 yamt fe = udf_node->fe;
351 1.1.2.3 yamt efe = udf_node->efe;
352 1.1.2.3 yamt if (fe) {
353 1.1.2.3 yamt icbtag = &fe->icbtag;
354 1.1.2.3 yamt inflen = udf_rw64(fe->inf_len);
355 1.1.2.3 yamt dscr_size = sizeof(struct file_entry) -1;
356 1.1.2.3 yamt logblksrec = udf_rw64(fe->logblks_rec);
357 1.1.2.3 yamt } else {
358 1.1.2.3 yamt icbtag = &efe->icbtag;
359 1.1.2.3 yamt inflen = udf_rw64(efe->inf_len);
360 1.1.2.3 yamt dscr_size = sizeof(struct extfile_entry) -1;
361 1.1.2.3 yamt logblksrec = udf_rw64(efe->logblks_rec);
362 1.1.2.3 yamt }
363 1.1.2.3 yamt *cnt_logblksrec = logblksrec;
364 1.1.2.3 yamt *cnt_inflen = inflen;
365 1.1.2.3 yamt }
366 1.1.2.2 yamt #endif
367 1.1.2.2 yamt
368 1.1.2.2 yamt /* --------------------------------------------------------------------- */
369 1.1.2.2 yamt
370 1.1.2.5 yamt void
371 1.1.2.5 yamt udf_calc_freespace(struct udf_mount *ump, uint64_t *sizeblks, uint64_t *freeblks)
372 1.1.2.5 yamt {
373 1.1.2.5 yamt struct logvol_int_desc *lvid;
374 1.1.2.5 yamt uint32_t *pos1, *pos2;
375 1.1.2.5 yamt int vpart, num_vpart;
376 1.1.2.5 yamt
377 1.1.2.5 yamt lvid = ump->logvol_integrity;
378 1.1.2.5 yamt *freeblks = *sizeblks = 0;
379 1.1.2.5 yamt
380 1.1.2.5 yamt /*
381 1.1.2.5 yamt * Sequentials media report free space directly (CD/DVD/BD-R), for the
382 1.1.2.5 yamt * other media we need the logical volume integrity.
383 1.1.2.5 yamt *
384 1.1.2.5 yamt * We sum all free space up here regardless of type.
385 1.1.2.5 yamt */
386 1.1.2.5 yamt
387 1.1.2.5 yamt KASSERT(lvid);
388 1.1.2.5 yamt num_vpart = udf_rw32(lvid->num_part);
389 1.1.2.5 yamt
390 1.1.2.5 yamt if (ump->discinfo.mmc_cur & MMC_CAP_SEQUENTIAL) {
391 1.1.2.5 yamt /* use track info directly summing if there are 2 open */
392 1.1.2.5 yamt /* XXX assumption at most two tracks open */
393 1.1.2.5 yamt *freeblks = ump->data_track.free_blocks;
394 1.1.2.5 yamt if (ump->data_track.tracknr != ump->metadata_track.tracknr)
395 1.1.2.5 yamt *freeblks += ump->metadata_track.free_blocks;
396 1.1.2.5 yamt *sizeblks = ump->discinfo.last_possible_lba;
397 1.1.2.5 yamt } else {
398 1.1.2.5 yamt /* free and used space for mountpoint based on logvol integrity */
399 1.1.2.5 yamt for (vpart = 0; vpart < num_vpart; vpart++) {
400 1.1.2.5 yamt pos1 = &lvid->tables[0] + vpart;
401 1.1.2.5 yamt pos2 = &lvid->tables[0] + num_vpart + vpart;
402 1.1.2.5 yamt if (udf_rw32(*pos1) != (uint32_t) -1) {
403 1.1.2.5 yamt *freeblks += udf_rw32(*pos1);
404 1.1.2.5 yamt *sizeblks += udf_rw32(*pos2);
405 1.1.2.5 yamt }
406 1.1.2.5 yamt }
407 1.1.2.5 yamt }
408 1.1.2.5 yamt /* adjust for accounted uncommitted blocks */
409 1.1.2.5 yamt for (vpart = 0; vpart < num_vpart; vpart++)
410 1.1.2.5 yamt *freeblks -= ump->uncommitted_lbs[vpart];
411 1.1.2.5 yamt
412 1.1.2.5 yamt if (*freeblks > UDF_DISC_SLACK) {
413 1.1.2.5 yamt *freeblks -= UDF_DISC_SLACK;
414 1.1.2.5 yamt } else {
415 1.1.2.5 yamt *freeblks = 0;
416 1.1.2.5 yamt }
417 1.1.2.5 yamt }
418 1.1.2.5 yamt
419 1.1.2.5 yamt
420 1.1.2.5 yamt static void
421 1.1.2.5 yamt udf_calc_vpart_freespace(struct udf_mount *ump, uint16_t vpart_num, uint64_t *freeblks)
422 1.1.2.5 yamt {
423 1.1.2.5 yamt struct logvol_int_desc *lvid;
424 1.1.2.5 yamt uint32_t *pos1;
425 1.1.2.5 yamt
426 1.1.2.5 yamt lvid = ump->logvol_integrity;
427 1.1.2.5 yamt *freeblks = 0;
428 1.1.2.5 yamt
429 1.1.2.5 yamt /*
430 1.1.2.5 yamt * Sequentials media report free space directly (CD/DVD/BD-R), for the
431 1.1.2.5 yamt * other media we need the logical volume integrity.
432 1.1.2.5 yamt *
433 1.1.2.5 yamt * We sum all free space up here regardless of type.
434 1.1.2.5 yamt */
435 1.1.2.5 yamt
436 1.1.2.5 yamt KASSERT(lvid);
437 1.1.2.5 yamt if (ump->discinfo.mmc_cur & MMC_CAP_SEQUENTIAL) {
438 1.1.2.5 yamt /* XXX assumption at most two tracks open */
439 1.1.2.5 yamt if (vpart_num == ump->data_part) {
440 1.1.2.5 yamt *freeblks = ump->data_track.free_blocks;
441 1.1.2.5 yamt } else {
442 1.1.2.5 yamt *freeblks = ump->metadata_track.free_blocks;
443 1.1.2.5 yamt }
444 1.1.2.5 yamt } else {
445 1.1.2.5 yamt /* free and used space for mountpoint based on logvol integrity */
446 1.1.2.5 yamt pos1 = &lvid->tables[0] + vpart_num;
447 1.1.2.5 yamt if (udf_rw32(*pos1) != (uint32_t) -1)
448 1.1.2.5 yamt *freeblks += udf_rw32(*pos1);
449 1.1.2.5 yamt }
450 1.1.2.5 yamt
451 1.1.2.5 yamt /* adjust for accounted uncommitted blocks */
452 1.1.2.5 yamt *freeblks -= ump->uncommitted_lbs[vpart_num];
453 1.1.2.5 yamt }
454 1.1.2.5 yamt
455 1.1.2.5 yamt /* --------------------------------------------------------------------- */
456 1.1.2.5 yamt
457 1.1.2.2 yamt int
458 1.1.2.2 yamt udf_translate_vtop(struct udf_mount *ump, struct long_ad *icb_loc,
459 1.1.2.2 yamt uint32_t *lb_numres, uint32_t *extres)
460 1.1.2.2 yamt {
461 1.1.2.2 yamt struct part_desc *pdesc;
462 1.1.2.2 yamt struct spare_map_entry *sme;
463 1.1.2.2 yamt struct long_ad s_icb_loc;
464 1.1.2.2 yamt uint64_t foffset, end_foffset;
465 1.1.2.2 yamt uint32_t lb_size, len;
466 1.1.2.2 yamt uint32_t lb_num, lb_rel, lb_packet;
467 1.1.2.2 yamt uint32_t udf_rw32_lbmap, ext_offset;
468 1.1.2.2 yamt uint16_t vpart;
469 1.1.2.2 yamt int rel, part, error, eof, slot, flags;
470 1.1.2.2 yamt
471 1.1.2.2 yamt assert(ump && icb_loc && lb_numres);
472 1.1.2.2 yamt
473 1.1.2.2 yamt vpart = udf_rw16(icb_loc->loc.part_num);
474 1.1.2.2 yamt lb_num = udf_rw32(icb_loc->loc.lb_num);
475 1.1.2.2 yamt if (vpart > UDF_VTOP_RAWPART)
476 1.1.2.2 yamt return EINVAL;
477 1.1.2.2 yamt
478 1.1.2.2 yamt translate_again:
479 1.1.2.2 yamt part = ump->vtop[vpart];
480 1.1.2.2 yamt pdesc = ump->partitions[part];
481 1.1.2.2 yamt
482 1.1.2.2 yamt switch (ump->vtop_tp[vpart]) {
483 1.1.2.2 yamt case UDF_VTOP_TYPE_RAW :
484 1.1.2.2 yamt /* 1:1 to the end of the device */
485 1.1.2.2 yamt *lb_numres = lb_num;
486 1.1.2.2 yamt *extres = INT_MAX;
487 1.1.2.2 yamt return 0;
488 1.1.2.2 yamt case UDF_VTOP_TYPE_PHYS :
489 1.1.2.2 yamt /* transform into its disc logical block */
490 1.1.2.2 yamt if (lb_num > udf_rw32(pdesc->part_len))
491 1.1.2.2 yamt return EINVAL;
492 1.1.2.2 yamt *lb_numres = lb_num + udf_rw32(pdesc->start_loc);
493 1.1.2.2 yamt
494 1.1.2.2 yamt /* extent from here to the end of the partition */
495 1.1.2.2 yamt *extres = udf_rw32(pdesc->part_len) - lb_num;
496 1.1.2.2 yamt return 0;
497 1.1.2.2 yamt case UDF_VTOP_TYPE_VIRT :
498 1.1.2.2 yamt /* only maps one logical block, lookup in VAT */
499 1.1.2.2 yamt if (lb_num >= ump->vat_entries) /* XXX > or >= ? */
500 1.1.2.2 yamt return EINVAL;
501 1.1.2.2 yamt
502 1.1.2.2 yamt /* lookup in virtual allocation table file */
503 1.1.2.2 yamt mutex_enter(&ump->allocate_mutex);
504 1.1.2.2 yamt error = udf_vat_read(ump->vat_node,
505 1.1.2.2 yamt (uint8_t *) &udf_rw32_lbmap, 4,
506 1.1.2.2 yamt ump->vat_offset + lb_num * 4);
507 1.1.2.2 yamt mutex_exit(&ump->allocate_mutex);
508 1.1.2.2 yamt
509 1.1.2.2 yamt if (error)
510 1.1.2.2 yamt return error;
511 1.1.2.2 yamt
512 1.1.2.2 yamt lb_num = udf_rw32(udf_rw32_lbmap);
513 1.1.2.2 yamt
514 1.1.2.2 yamt /* transform into its disc logical block */
515 1.1.2.2 yamt if (lb_num > udf_rw32(pdesc->part_len))
516 1.1.2.2 yamt return EINVAL;
517 1.1.2.2 yamt *lb_numres = lb_num + udf_rw32(pdesc->start_loc);
518 1.1.2.2 yamt
519 1.1.2.2 yamt /* just one logical block */
520 1.1.2.2 yamt *extres = 1;
521 1.1.2.2 yamt return 0;
522 1.1.2.2 yamt case UDF_VTOP_TYPE_SPARABLE :
523 1.1.2.2 yamt /* check if the packet containing the lb_num is remapped */
524 1.1.2.2 yamt lb_packet = lb_num / ump->sparable_packet_size;
525 1.1.2.2 yamt lb_rel = lb_num % ump->sparable_packet_size;
526 1.1.2.2 yamt
527 1.1.2.2 yamt for (rel = 0; rel < udf_rw16(ump->sparing_table->rt_l); rel++) {
528 1.1.2.2 yamt sme = &ump->sparing_table->entries[rel];
529 1.1.2.2 yamt if (lb_packet == udf_rw32(sme->org)) {
530 1.1.2.2 yamt /* NOTE maps to absolute disc logical block! */
531 1.1.2.2 yamt *lb_numres = udf_rw32(sme->map) + lb_rel;
532 1.1.2.2 yamt *extres = ump->sparable_packet_size - lb_rel;
533 1.1.2.2 yamt return 0;
534 1.1.2.2 yamt }
535 1.1.2.2 yamt }
536 1.1.2.2 yamt
537 1.1.2.2 yamt /* transform into its disc logical block */
538 1.1.2.2 yamt if (lb_num > udf_rw32(pdesc->part_len))
539 1.1.2.2 yamt return EINVAL;
540 1.1.2.2 yamt *lb_numres = lb_num + udf_rw32(pdesc->start_loc);
541 1.1.2.2 yamt
542 1.1.2.2 yamt /* rest of block */
543 1.1.2.2 yamt *extres = ump->sparable_packet_size - lb_rel;
544 1.1.2.2 yamt return 0;
545 1.1.2.2 yamt case UDF_VTOP_TYPE_META :
546 1.1.2.2 yamt /* we have to look into the file's allocation descriptors */
547 1.1.2.2 yamt
548 1.1.2.2 yamt /* use metadatafile allocation mutex */
549 1.1.2.2 yamt lb_size = udf_rw32(ump->logical_vol->lb_size);
550 1.1.2.2 yamt
551 1.1.2.2 yamt UDF_LOCK_NODE(ump->metadata_node, 0);
552 1.1.2.2 yamt
553 1.1.2.2 yamt /* get first overlapping extent */
554 1.1.2.2 yamt foffset = 0;
555 1.1.2.2 yamt slot = 0;
556 1.1.2.2 yamt for (;;) {
557 1.1.2.2 yamt udf_get_adslot(ump->metadata_node,
558 1.1.2.2 yamt slot, &s_icb_loc, &eof);
559 1.1.2.3 yamt DPRINTF(ADWLK, ("slot %d, eof = %d, flags = %d, "
560 1.1.2.3 yamt "len = %d, lb_num = %d, part = %d\n",
561 1.1.2.3 yamt slot, eof,
562 1.1.2.3 yamt UDF_EXT_FLAGS(udf_rw32(s_icb_loc.len)),
563 1.1.2.3 yamt UDF_EXT_LEN(udf_rw32(s_icb_loc.len)),
564 1.1.2.3 yamt udf_rw32(s_icb_loc.loc.lb_num),
565 1.1.2.3 yamt udf_rw16(s_icb_loc.loc.part_num)));
566 1.1.2.2 yamt if (eof) {
567 1.1.2.2 yamt DPRINTF(TRANSLATE,
568 1.1.2.2 yamt ("Meta partition translation "
569 1.1.2.2 yamt "failed: can't seek location\n"));
570 1.1.2.2 yamt UDF_UNLOCK_NODE(ump->metadata_node, 0);
571 1.1.2.2 yamt return EINVAL;
572 1.1.2.2 yamt }
573 1.1.2.2 yamt len = udf_rw32(s_icb_loc.len);
574 1.1.2.2 yamt flags = UDF_EXT_FLAGS(len);
575 1.1.2.2 yamt len = UDF_EXT_LEN(len);
576 1.1.2.2 yamt
577 1.1.2.3 yamt if (flags == UDF_EXT_REDIRECT) {
578 1.1.2.3 yamt slot++;
579 1.1.2.3 yamt continue;
580 1.1.2.3 yamt }
581 1.1.2.3 yamt
582 1.1.2.2 yamt end_foffset = foffset + len;
583 1.1.2.2 yamt
584 1.1.2.2 yamt if (end_foffset > lb_num * lb_size)
585 1.1.2.2 yamt break; /* found */
586 1.1.2.3 yamt foffset = end_foffset;
587 1.1.2.2 yamt slot++;
588 1.1.2.2 yamt }
589 1.1.2.2 yamt /* found overlapping slot */
590 1.1.2.2 yamt ext_offset = lb_num * lb_size - foffset;
591 1.1.2.2 yamt
592 1.1.2.2 yamt /* process extent offset */
593 1.1.2.2 yamt lb_num = udf_rw32(s_icb_loc.loc.lb_num);
594 1.1.2.2 yamt vpart = udf_rw16(s_icb_loc.loc.part_num);
595 1.1.2.2 yamt lb_num += (ext_offset + lb_size -1) / lb_size;
596 1.1.2.2 yamt ext_offset = 0;
597 1.1.2.2 yamt
598 1.1.2.2 yamt UDF_UNLOCK_NODE(ump->metadata_node, 0);
599 1.1.2.2 yamt if (flags != UDF_EXT_ALLOCATED) {
600 1.1.2.2 yamt DPRINTF(TRANSLATE, ("Metadata partition translation "
601 1.1.2.2 yamt "failed: not allocated\n"));
602 1.1.2.2 yamt return EINVAL;
603 1.1.2.2 yamt }
604 1.1.2.2 yamt
605 1.1.2.2 yamt /*
606 1.1.2.2 yamt * vpart and lb_num are updated, translate again since we
607 1.1.2.2 yamt * might be mapped on sparable media
608 1.1.2.2 yamt */
609 1.1.2.2 yamt goto translate_again;
610 1.1.2.2 yamt default:
611 1.1.2.2 yamt printf("UDF vtop translation scheme %d unimplemented yet\n",
612 1.1.2.2 yamt ump->vtop_tp[vpart]);
613 1.1.2.2 yamt }
614 1.1.2.2 yamt
615 1.1.2.2 yamt return EINVAL;
616 1.1.2.2 yamt }
617 1.1.2.2 yamt
618 1.1.2.3 yamt
619 1.1.2.3 yamt /* XXX provisional primitive braindead version */
620 1.1.2.3 yamt /* TODO use ext_res */
621 1.1.2.3 yamt void
622 1.1.2.3 yamt udf_translate_vtop_list(struct udf_mount *ump, uint32_t sectors,
623 1.1.2.3 yamt uint16_t vpart_num, uint64_t *lmapping, uint64_t *pmapping)
624 1.1.2.3 yamt {
625 1.1.2.3 yamt struct long_ad loc;
626 1.1.2.3 yamt uint32_t lb_numres, ext_res;
627 1.1.2.3 yamt int sector;
628 1.1.2.3 yamt
629 1.1.2.3 yamt for (sector = 0; sector < sectors; sector++) {
630 1.1.2.3 yamt memset(&loc, 0, sizeof(struct long_ad));
631 1.1.2.3 yamt loc.loc.part_num = udf_rw16(vpart_num);
632 1.1.2.3 yamt loc.loc.lb_num = udf_rw32(*lmapping);
633 1.1.2.3 yamt udf_translate_vtop(ump, &loc, &lb_numres, &ext_res);
634 1.1.2.3 yamt *pmapping = lb_numres;
635 1.1.2.3 yamt lmapping++; pmapping++;
636 1.1.2.3 yamt }
637 1.1.2.3 yamt }
638 1.1.2.3 yamt
639 1.1.2.3 yamt
640 1.1.2.2 yamt /* --------------------------------------------------------------------- */
641 1.1.2.2 yamt
642 1.1.2.2 yamt /*
643 1.1.2.2 yamt * Translate an extent (in logical_blocks) into logical block numbers; used
644 1.1.2.2 yamt * for read and write operations. DOESNT't check extents.
645 1.1.2.2 yamt */
646 1.1.2.2 yamt
647 1.1.2.2 yamt int
648 1.1.2.2 yamt udf_translate_file_extent(struct udf_node *udf_node,
649 1.1.2.2 yamt uint32_t from, uint32_t num_lb,
650 1.1.2.2 yamt uint64_t *map)
651 1.1.2.2 yamt {
652 1.1.2.2 yamt struct udf_mount *ump;
653 1.1.2.2 yamt struct icb_tag *icbtag;
654 1.1.2.2 yamt struct long_ad t_ad, s_ad;
655 1.1.2.2 yamt uint64_t transsec;
656 1.1.2.2 yamt uint64_t foffset, end_foffset;
657 1.1.2.2 yamt uint32_t transsec32;
658 1.1.2.2 yamt uint32_t lb_size;
659 1.1.2.2 yamt uint32_t ext_offset;
660 1.1.2.2 yamt uint32_t lb_num, len;
661 1.1.2.2 yamt uint32_t overlap, translen;
662 1.1.2.2 yamt uint16_t vpart_num;
663 1.1.2.2 yamt int eof, error, flags;
664 1.1.2.2 yamt int slot, addr_type, icbflags;
665 1.1.2.2 yamt
666 1.1.2.2 yamt if (!udf_node)
667 1.1.2.2 yamt return ENOENT;
668 1.1.2.2 yamt
669 1.1.2.2 yamt KASSERT(num_lb > 0);
670 1.1.2.2 yamt
671 1.1.2.2 yamt UDF_LOCK_NODE(udf_node, 0);
672 1.1.2.2 yamt
673 1.1.2.2 yamt /* initialise derivative vars */
674 1.1.2.2 yamt ump = udf_node->ump;
675 1.1.2.2 yamt lb_size = udf_rw32(ump->logical_vol->lb_size);
676 1.1.2.2 yamt
677 1.1.2.2 yamt if (udf_node->fe) {
678 1.1.2.2 yamt icbtag = &udf_node->fe->icbtag;
679 1.1.2.2 yamt } else {
680 1.1.2.2 yamt icbtag = &udf_node->efe->icbtag;
681 1.1.2.2 yamt }
682 1.1.2.2 yamt icbflags = udf_rw16(icbtag->flags);
683 1.1.2.2 yamt addr_type = icbflags & UDF_ICB_TAG_FLAGS_ALLOC_MASK;
684 1.1.2.2 yamt
685 1.1.2.2 yamt /* do the work */
686 1.1.2.2 yamt if (addr_type == UDF_ICB_INTERN_ALLOC) {
687 1.1.2.2 yamt *map = UDF_TRANS_INTERN;
688 1.1.2.2 yamt UDF_UNLOCK_NODE(udf_node, 0);
689 1.1.2.2 yamt return 0;
690 1.1.2.2 yamt }
691 1.1.2.2 yamt
692 1.1.2.2 yamt /* find first overlapping extent */
693 1.1.2.2 yamt foffset = 0;
694 1.1.2.2 yamt slot = 0;
695 1.1.2.2 yamt for (;;) {
696 1.1.2.2 yamt udf_get_adslot(udf_node, slot, &s_ad, &eof);
697 1.1.2.3 yamt DPRINTF(ADWLK, ("slot %d, eof = %d, flags = %d, len = %d, "
698 1.1.2.3 yamt "lb_num = %d, part = %d\n", slot, eof,
699 1.1.2.3 yamt UDF_EXT_FLAGS(udf_rw32(s_ad.len)),
700 1.1.2.3 yamt UDF_EXT_LEN(udf_rw32(s_ad.len)),
701 1.1.2.3 yamt udf_rw32(s_ad.loc.lb_num),
702 1.1.2.3 yamt udf_rw16(s_ad.loc.part_num)));
703 1.1.2.2 yamt if (eof) {
704 1.1.2.2 yamt DPRINTF(TRANSLATE,
705 1.1.2.2 yamt ("Translate file extent "
706 1.1.2.2 yamt "failed: can't seek location\n"));
707 1.1.2.2 yamt UDF_UNLOCK_NODE(udf_node, 0);
708 1.1.2.2 yamt return EINVAL;
709 1.1.2.2 yamt }
710 1.1.2.2 yamt len = udf_rw32(s_ad.len);
711 1.1.2.2 yamt flags = UDF_EXT_FLAGS(len);
712 1.1.2.2 yamt len = UDF_EXT_LEN(len);
713 1.1.2.2 yamt lb_num = udf_rw32(s_ad.loc.lb_num);
714 1.1.2.2 yamt
715 1.1.2.2 yamt if (flags == UDF_EXT_REDIRECT) {
716 1.1.2.2 yamt slot++;
717 1.1.2.2 yamt continue;
718 1.1.2.2 yamt }
719 1.1.2.2 yamt
720 1.1.2.2 yamt end_foffset = foffset + len;
721 1.1.2.2 yamt
722 1.1.2.2 yamt if (end_foffset > from * lb_size)
723 1.1.2.2 yamt break; /* found */
724 1.1.2.2 yamt foffset = end_foffset;
725 1.1.2.2 yamt slot++;
726 1.1.2.2 yamt }
727 1.1.2.2 yamt /* found overlapping slot */
728 1.1.2.2 yamt ext_offset = from * lb_size - foffset;
729 1.1.2.2 yamt
730 1.1.2.2 yamt for (;;) {
731 1.1.2.2 yamt udf_get_adslot(udf_node, slot, &s_ad, &eof);
732 1.1.2.3 yamt DPRINTF(ADWLK, ("slot %d, eof = %d, flags = %d, len = %d, "
733 1.1.2.3 yamt "lb_num = %d, part = %d\n", slot, eof,
734 1.1.2.3 yamt UDF_EXT_FLAGS(udf_rw32(s_ad.len)),
735 1.1.2.3 yamt UDF_EXT_LEN(udf_rw32(s_ad.len)),
736 1.1.2.3 yamt udf_rw32(s_ad.loc.lb_num),
737 1.1.2.3 yamt udf_rw16(s_ad.loc.part_num)));
738 1.1.2.2 yamt if (eof) {
739 1.1.2.2 yamt DPRINTF(TRANSLATE,
740 1.1.2.2 yamt ("Translate file extent "
741 1.1.2.2 yamt "failed: past eof\n"));
742 1.1.2.2 yamt UDF_UNLOCK_NODE(udf_node, 0);
743 1.1.2.2 yamt return EINVAL;
744 1.1.2.2 yamt }
745 1.1.2.2 yamt
746 1.1.2.2 yamt len = udf_rw32(s_ad.len);
747 1.1.2.2 yamt flags = UDF_EXT_FLAGS(len);
748 1.1.2.2 yamt len = UDF_EXT_LEN(len);
749 1.1.2.2 yamt
750 1.1.2.2 yamt lb_num = udf_rw32(s_ad.loc.lb_num);
751 1.1.2.2 yamt vpart_num = udf_rw16(s_ad.loc.part_num);
752 1.1.2.2 yamt
753 1.1.2.2 yamt end_foffset = foffset + len;
754 1.1.2.2 yamt
755 1.1.2.2 yamt /* process extent, don't forget to advance on ext_offset! */
756 1.1.2.2 yamt lb_num += (ext_offset + lb_size -1) / lb_size;
757 1.1.2.2 yamt overlap = (len - ext_offset + lb_size -1) / lb_size;
758 1.1.2.2 yamt ext_offset = 0;
759 1.1.2.2 yamt
760 1.1.2.2 yamt /*
761 1.1.2.2 yamt * note that the while(){} is nessisary for the extent that
762 1.1.2.2 yamt * the udf_translate_vtop() returns doens't have to span the
763 1.1.2.2 yamt * whole extent.
764 1.1.2.2 yamt */
765 1.1.2.2 yamt
766 1.1.2.2 yamt overlap = MIN(overlap, num_lb);
767 1.1.2.3 yamt while (overlap && (flags != UDF_EXT_REDIRECT)) {
768 1.1.2.2 yamt switch (flags) {
769 1.1.2.2 yamt case UDF_EXT_FREE :
770 1.1.2.2 yamt case UDF_EXT_ALLOCATED_BUT_NOT_USED :
771 1.1.2.2 yamt transsec = UDF_TRANS_ZERO;
772 1.1.2.2 yamt translen = overlap;
773 1.1.2.2 yamt while (overlap && num_lb && translen) {
774 1.1.2.2 yamt *map++ = transsec;
775 1.1.2.2 yamt lb_num++;
776 1.1.2.2 yamt overlap--; num_lb--; translen--;
777 1.1.2.2 yamt }
778 1.1.2.2 yamt break;
779 1.1.2.2 yamt case UDF_EXT_ALLOCATED :
780 1.1.2.2 yamt t_ad.loc.lb_num = udf_rw32(lb_num);
781 1.1.2.2 yamt t_ad.loc.part_num = udf_rw16(vpart_num);
782 1.1.2.2 yamt error = udf_translate_vtop(ump,
783 1.1.2.2 yamt &t_ad, &transsec32, &translen);
784 1.1.2.2 yamt transsec = transsec32;
785 1.1.2.2 yamt if (error) {
786 1.1.2.2 yamt UDF_UNLOCK_NODE(udf_node, 0);
787 1.1.2.2 yamt return error;
788 1.1.2.2 yamt }
789 1.1.2.2 yamt while (overlap && num_lb && translen) {
790 1.1.2.2 yamt *map++ = transsec;
791 1.1.2.2 yamt lb_num++; transsec++;
792 1.1.2.2 yamt overlap--; num_lb--; translen--;
793 1.1.2.2 yamt }
794 1.1.2.2 yamt break;
795 1.1.2.3 yamt default:
796 1.1.2.3 yamt DPRINTF(TRANSLATE,
797 1.1.2.3 yamt ("Translate file extent "
798 1.1.2.3 yamt "failed: bad flags %x\n", flags));
799 1.1.2.3 yamt UDF_UNLOCK_NODE(udf_node, 0);
800 1.1.2.3 yamt return EINVAL;
801 1.1.2.2 yamt }
802 1.1.2.2 yamt }
803 1.1.2.2 yamt if (num_lb == 0)
804 1.1.2.2 yamt break;
805 1.1.2.2 yamt
806 1.1.2.2 yamt if (flags != UDF_EXT_REDIRECT)
807 1.1.2.2 yamt foffset = end_foffset;
808 1.1.2.2 yamt slot++;
809 1.1.2.2 yamt }
810 1.1.2.2 yamt UDF_UNLOCK_NODE(udf_node, 0);
811 1.1.2.2 yamt
812 1.1.2.2 yamt return 0;
813 1.1.2.2 yamt }
814 1.1.2.2 yamt
815 1.1.2.2 yamt /* --------------------------------------------------------------------- */
816 1.1.2.2 yamt
817 1.1.2.2 yamt static int
818 1.1.2.2 yamt udf_search_free_vatloc(struct udf_mount *ump, uint32_t *lbnumres)
819 1.1.2.2 yamt {
820 1.1.2.2 yamt uint32_t lb_size, lb_num, lb_map, udf_rw32_lbmap;
821 1.1.2.2 yamt uint8_t *blob;
822 1.1.2.2 yamt int entry, chunk, found, error;
823 1.1.2.2 yamt
824 1.1.2.2 yamt KASSERT(ump);
825 1.1.2.2 yamt KASSERT(ump->logical_vol);
826 1.1.2.2 yamt
827 1.1.2.2 yamt lb_size = udf_rw32(ump->logical_vol->lb_size);
828 1.1.2.2 yamt blob = malloc(lb_size, M_UDFTEMP, M_WAITOK);
829 1.1.2.2 yamt
830 1.1.2.2 yamt /* TODO static allocation of search chunk */
831 1.1.2.2 yamt
832 1.1.2.2 yamt lb_num = MIN(ump->vat_entries, ump->vat_last_free_lb);
833 1.1.2.2 yamt found = 0;
834 1.1.2.2 yamt error = 0;
835 1.1.2.2 yamt entry = 0;
836 1.1.2.2 yamt do {
837 1.1.2.2 yamt chunk = MIN(lb_size, (ump->vat_entries - lb_num) * 4);
838 1.1.2.2 yamt if (chunk <= 0)
839 1.1.2.2 yamt break;
840 1.1.2.2 yamt /* load in chunk */
841 1.1.2.2 yamt error = udf_vat_read(ump->vat_node, blob, chunk,
842 1.1.2.2 yamt ump->vat_offset + lb_num * 4);
843 1.1.2.2 yamt
844 1.1.2.2 yamt if (error)
845 1.1.2.2 yamt break;
846 1.1.2.2 yamt
847 1.1.2.2 yamt /* search this chunk */
848 1.1.2.2 yamt for (entry=0; entry < chunk /4; entry++, lb_num++) {
849 1.1.2.2 yamt udf_rw32_lbmap = *((uint32_t *) (blob + entry * 4));
850 1.1.2.2 yamt lb_map = udf_rw32(udf_rw32_lbmap);
851 1.1.2.2 yamt if (lb_map == 0xffffffff) {
852 1.1.2.2 yamt found = 1;
853 1.1.2.2 yamt break;
854 1.1.2.2 yamt }
855 1.1.2.2 yamt }
856 1.1.2.2 yamt } while (!found);
857 1.1.2.2 yamt if (error) {
858 1.1.2.2 yamt printf("udf_search_free_vatloc: error reading in vat chunk "
859 1.1.2.2 yamt "(lb %d, size %d)\n", lb_num, chunk);
860 1.1.2.2 yamt }
861 1.1.2.2 yamt
862 1.1.2.2 yamt if (!found) {
863 1.1.2.2 yamt /* extend VAT */
864 1.1.2.2 yamt DPRINTF(WRITE, ("udf_search_free_vatloc: extending\n"));
865 1.1.2.2 yamt lb_num = ump->vat_entries;
866 1.1.2.2 yamt ump->vat_entries++;
867 1.1.2.2 yamt }
868 1.1.2.2 yamt
869 1.1.2.2 yamt /* mark entry with initialiser just in case */
870 1.1.2.2 yamt lb_map = udf_rw32(0xfffffffe);
871 1.1.2.2 yamt udf_vat_write(ump->vat_node, (uint8_t *) &lb_map, 4,
872 1.1.2.2 yamt ump->vat_offset + lb_num *4);
873 1.1.2.2 yamt ump->vat_last_free_lb = lb_num;
874 1.1.2.2 yamt
875 1.1.2.2 yamt free(blob, M_UDFTEMP);
876 1.1.2.2 yamt *lbnumres = lb_num;
877 1.1.2.2 yamt return 0;
878 1.1.2.2 yamt }
879 1.1.2.2 yamt
880 1.1.2.2 yamt
881 1.1.2.2 yamt static void
882 1.1.2.2 yamt udf_bitmap_allocate(struct udf_bitmap *bitmap, int ismetadata,
883 1.1.2.3 yamt uint32_t *num_lb, uint64_t *lmappos)
884 1.1.2.2 yamt {
885 1.1.2.2 yamt uint32_t offset, lb_num, bit;
886 1.1.2.2 yamt int32_t diff;
887 1.1.2.2 yamt uint8_t *bpos;
888 1.1.2.2 yamt int pass;
889 1.1.2.2 yamt
890 1.1.2.2 yamt if (!ismetadata) {
891 1.1.2.2 yamt /* heuristic to keep the two pointers not too close */
892 1.1.2.2 yamt diff = bitmap->data_pos - bitmap->metadata_pos;
893 1.1.2.2 yamt if ((diff >= 0) && (diff < 1024))
894 1.1.2.2 yamt bitmap->data_pos = bitmap->metadata_pos + 1024;
895 1.1.2.2 yamt }
896 1.1.2.2 yamt offset = ismetadata ? bitmap->metadata_pos : bitmap->data_pos;
897 1.1.2.2 yamt offset &= ~7;
898 1.1.2.2 yamt for (pass = 0; pass < 2; pass++) {
899 1.1.2.2 yamt if (offset >= bitmap->max_offset)
900 1.1.2.2 yamt offset = 0;
901 1.1.2.2 yamt
902 1.1.2.2 yamt while (offset < bitmap->max_offset) {
903 1.1.2.2 yamt if (*num_lb == 0)
904 1.1.2.2 yamt break;
905 1.1.2.2 yamt
906 1.1.2.2 yamt /* use first bit not set */
907 1.1.2.2 yamt bpos = bitmap->bits + offset/8;
908 1.1.2.3 yamt bit = ffs(*bpos); /* returns 0 or 1..8 */
909 1.1.2.2 yamt if (bit == 0) {
910 1.1.2.2 yamt offset += 8;
911 1.1.2.2 yamt continue;
912 1.1.2.2 yamt }
913 1.1.2.3 yamt
914 1.1.2.3 yamt /* check for ffs overshoot */
915 1.1.2.3 yamt if (offset + bit-1 >= bitmap->max_offset) {
916 1.1.2.3 yamt offset = bitmap->max_offset;
917 1.1.2.3 yamt break;
918 1.1.2.3 yamt }
919 1.1.2.3 yamt
920 1.1.2.3 yamt DPRINTF(PARANOIA, ("XXX : allocate %d, %p, bit %d\n",
921 1.1.2.3 yamt offset + bit -1, bpos, bit-1));
922 1.1.2.2 yamt *bpos &= ~(1 << (bit-1));
923 1.1.2.2 yamt lb_num = offset + bit-1;
924 1.1.2.2 yamt *lmappos++ = lb_num;
925 1.1.2.2 yamt *num_lb = *num_lb - 1;
926 1.1.2.2 yamt // offset = (offset & ~7);
927 1.1.2.2 yamt }
928 1.1.2.2 yamt }
929 1.1.2.2 yamt
930 1.1.2.2 yamt if (ismetadata) {
931 1.1.2.2 yamt bitmap->metadata_pos = offset;
932 1.1.2.2 yamt } else {
933 1.1.2.2 yamt bitmap->data_pos = offset;
934 1.1.2.2 yamt }
935 1.1.2.2 yamt }
936 1.1.2.2 yamt
937 1.1.2.2 yamt
938 1.1.2.2 yamt static void
939 1.1.2.2 yamt udf_bitmap_free(struct udf_bitmap *bitmap, uint32_t lb_num, uint32_t num_lb)
940 1.1.2.2 yamt {
941 1.1.2.2 yamt uint32_t offset;
942 1.1.2.2 yamt uint32_t bit, bitval;
943 1.1.2.2 yamt uint8_t *bpos;
944 1.1.2.2 yamt
945 1.1.2.2 yamt offset = lb_num;
946 1.1.2.2 yamt
947 1.1.2.2 yamt /* starter bits */
948 1.1.2.2 yamt bpos = bitmap->bits + offset/8;
949 1.1.2.2 yamt bit = offset % 8;
950 1.1.2.2 yamt while ((bit != 0) && (num_lb > 0)) {
951 1.1.2.2 yamt bitval = (1 << bit);
952 1.1.2.2 yamt KASSERT((*bpos & bitval) == 0);
953 1.1.2.3 yamt DPRINTF(PARANOIA, ("XXX : free %d, %p, %d\n",
954 1.1.2.3 yamt offset, bpos, bit));
955 1.1.2.2 yamt *bpos |= bitval;
956 1.1.2.2 yamt offset++; num_lb--;
957 1.1.2.2 yamt bit = (bit + 1) % 8;
958 1.1.2.2 yamt }
959 1.1.2.2 yamt if (num_lb == 0)
960 1.1.2.2 yamt return;
961 1.1.2.2 yamt
962 1.1.2.2 yamt /* whole bytes */
963 1.1.2.2 yamt KASSERT(bit == 0);
964 1.1.2.2 yamt bpos = bitmap->bits + offset / 8;
965 1.1.2.2 yamt while (num_lb >= 8) {
966 1.1.2.2 yamt KASSERT((*bpos == 0));
967 1.1.2.3 yamt DPRINTF(PARANOIA, ("XXX : free %d + 8, %p\n", offset, bpos));
968 1.1.2.2 yamt *bpos = 255;
969 1.1.2.2 yamt offset += 8; num_lb -= 8;
970 1.1.2.2 yamt bpos++;
971 1.1.2.2 yamt }
972 1.1.2.2 yamt
973 1.1.2.2 yamt /* stop bits */
974 1.1.2.2 yamt KASSERT(num_lb < 8);
975 1.1.2.2 yamt bit = 0;
976 1.1.2.2 yamt while (num_lb > 0) {
977 1.1.2.2 yamt bitval = (1 << bit);
978 1.1.2.2 yamt KASSERT((*bpos & bitval) == 0);
979 1.1.2.3 yamt DPRINTF(PARANOIA, ("XXX : free %d, %p, %d\n",
980 1.1.2.3 yamt offset, bpos, bit));
981 1.1.2.2 yamt *bpos |= bitval;
982 1.1.2.2 yamt offset++; num_lb--;
983 1.1.2.2 yamt bit = (bit + 1) % 8;
984 1.1.2.2 yamt }
985 1.1.2.2 yamt }
986 1.1.2.2 yamt
987 1.1.2.5 yamt /* --------------------------------------------------------------------- */
988 1.1.2.2 yamt
989 1.1.2.5 yamt /*
990 1.1.2.5 yamt * We check for overall disc space with a margin to prevent critical
991 1.1.2.5 yamt * conditions. If disc space is low we try to force a sync() to improve our
992 1.1.2.5 yamt * estimates. When confronted with meta-data partition size shortage we know
993 1.1.2.5 yamt * we have to check if it can be extended and we need to extend it when
994 1.1.2.5 yamt * needed.
995 1.1.2.5 yamt *
996 1.1.2.5 yamt * A 2nd strategy we could use when disc space is getting low on a disc
997 1.1.2.5 yamt * formatted with a meta-data partition is to see if there are sparse areas in
998 1.1.2.5 yamt * the meta-data partition and free blocks there for extra data.
999 1.1.2.5 yamt */
1000 1.1.2.5 yamt
1001 1.1.2.5 yamt void
1002 1.1.2.5 yamt udf_do_reserve_space(struct udf_mount *ump, struct udf_node *udf_node,
1003 1.1.2.5 yamt uint16_t vpart_num, uint32_t num_lb)
1004 1.1.2.5 yamt {
1005 1.1.2.5 yamt ump->uncommitted_lbs[vpart_num] += num_lb;
1006 1.1.2.5 yamt if (udf_node)
1007 1.1.2.5 yamt udf_node->uncommitted_lbs += num_lb;
1008 1.1.2.5 yamt }
1009 1.1.2.5 yamt
1010 1.1.2.5 yamt
1011 1.1.2.5 yamt void
1012 1.1.2.5 yamt udf_do_unreserve_space(struct udf_mount *ump, struct udf_node *udf_node,
1013 1.1.2.5 yamt uint16_t vpart_num, uint32_t num_lb)
1014 1.1.2.5 yamt {
1015 1.1.2.5 yamt ump->uncommitted_lbs[vpart_num] -= num_lb;
1016 1.1.2.5 yamt if (ump->uncommitted_lbs[vpart_num] < 0) {
1017 1.1.2.5 yamt DPRINTF(RESERVE, ("UDF: underflow on partition reservation, "
1018 1.1.2.5 yamt "part %d: %d\n", vpart_num,
1019 1.1.2.5 yamt ump->uncommitted_lbs[vpart_num]));
1020 1.1.2.5 yamt ump->uncommitted_lbs[vpart_num] = 0;
1021 1.1.2.5 yamt }
1022 1.1.2.5 yamt if (udf_node) {
1023 1.1.2.5 yamt udf_node->uncommitted_lbs -= num_lb;
1024 1.1.2.5 yamt if (udf_node->uncommitted_lbs < 0) {
1025 1.1.2.5 yamt DPRINTF(RESERVE, ("UDF: underflow of node "
1026 1.1.2.5 yamt "reservation : %d\n",
1027 1.1.2.5 yamt udf_node->uncommitted_lbs));
1028 1.1.2.5 yamt udf_node->uncommitted_lbs = 0;
1029 1.1.2.5 yamt }
1030 1.1.2.5 yamt }
1031 1.1.2.5 yamt }
1032 1.1.2.5 yamt
1033 1.1.2.5 yamt
1034 1.1.2.5 yamt int
1035 1.1.2.5 yamt udf_reserve_space(struct udf_mount *ump, struct udf_node *udf_node,
1036 1.1.2.5 yamt int udf_c_type, uint16_t vpart_num, uint32_t num_lb, int can_fail)
1037 1.1.2.5 yamt {
1038 1.1.2.5 yamt uint64_t freeblks;
1039 1.1.2.5 yamt uint64_t slack;
1040 1.1.2.5 yamt int i, error;
1041 1.1.2.5 yamt
1042 1.1.2.5 yamt slack = 0;
1043 1.1.2.5 yamt if (can_fail)
1044 1.1.2.5 yamt slack = UDF_DISC_SLACK;
1045 1.1.2.5 yamt
1046 1.1.2.5 yamt error = 0;
1047 1.1.2.5 yamt mutex_enter(&ump->allocate_mutex);
1048 1.1.2.5 yamt
1049 1.1.2.5 yamt /* check if there is enough space available */
1050 1.1.2.5 yamt for (i = 0; i < 16; i++) { /* XXX arbitrary number */
1051 1.1.2.5 yamt udf_calc_vpart_freespace(ump, vpart_num, &freeblks);
1052 1.1.2.5 yamt if (num_lb + slack < freeblks)
1053 1.1.2.5 yamt break;
1054 1.1.2.5 yamt /* issue SYNC */
1055 1.1.2.5 yamt DPRINTF(RESERVE, ("udf_reserve_space: issuing sync\n"));
1056 1.1.2.5 yamt mutex_exit(&ump->allocate_mutex);
1057 1.1.2.5 yamt udf_do_sync(ump, FSCRED, 0);
1058 1.1.2.5 yamt mutex_enter(&mntvnode_lock);
1059 1.1.2.5 yamt /* 1/4 second wait */
1060 1.1.2.5 yamt cv_timedwait(&ump->dirtynodes_cv, &mntvnode_lock,
1061 1.1.2.5 yamt hz/4);
1062 1.1.2.5 yamt mutex_exit(&mntvnode_lock);
1063 1.1.2.5 yamt mutex_enter(&ump->allocate_mutex);
1064 1.1.2.5 yamt }
1065 1.1.2.5 yamt
1066 1.1.2.5 yamt /* check if there is enough space available now */
1067 1.1.2.5 yamt udf_calc_vpart_freespace(ump, vpart_num, &freeblks);
1068 1.1.2.5 yamt if (num_lb + slack >= freeblks) {
1069 1.1.2.5 yamt DPRINTF(RESERVE, ("udf_reserve_space: try to juggle partitions\n"));
1070 1.1.2.5 yamt /* TODO juggle with data and metadata partitions if possible */
1071 1.1.2.5 yamt }
1072 1.1.2.5 yamt
1073 1.1.2.5 yamt /* check if there is enough space available now */
1074 1.1.2.5 yamt udf_calc_vpart_freespace(ump, vpart_num, &freeblks);
1075 1.1.2.5 yamt if (num_lb + slack <= freeblks) {
1076 1.1.2.5 yamt udf_do_reserve_space(ump, udf_node, vpart_num, num_lb);
1077 1.1.2.5 yamt } else {
1078 1.1.2.5 yamt DPRINTF(RESERVE, ("udf_reserve_space: out of disc space\n"));
1079 1.1.2.5 yamt error = ENOSPC;
1080 1.1.2.5 yamt }
1081 1.1.2.5 yamt
1082 1.1.2.5 yamt mutex_exit(&ump->allocate_mutex);
1083 1.1.2.5 yamt return error;
1084 1.1.2.5 yamt }
1085 1.1.2.5 yamt
1086 1.1.2.5 yamt
1087 1.1.2.5 yamt void
1088 1.1.2.5 yamt udf_cleanup_reservation(struct udf_node *udf_node)
1089 1.1.2.5 yamt {
1090 1.1.2.5 yamt struct udf_mount *ump = udf_node->ump;
1091 1.1.2.5 yamt int vpart_num;
1092 1.1.2.5 yamt
1093 1.1.2.5 yamt mutex_enter(&ump->allocate_mutex);
1094 1.1.2.5 yamt
1095 1.1.2.5 yamt /* compensate for overlapping blocks */
1096 1.1.2.5 yamt DPRINTF(RESERVE, ("UDF: overlapped %d blocks in count\n", udf_node->uncommitted_lbs));
1097 1.1.2.5 yamt
1098 1.1.2.5 yamt vpart_num = udf_get_record_vpart(ump, udf_get_c_type(udf_node));
1099 1.1.2.5 yamt udf_do_unreserve_space(ump, udf_node, vpart_num, udf_node->uncommitted_lbs);
1100 1.1.2.5 yamt
1101 1.1.2.5 yamt DPRINTF(RESERVE, ("\ttotal now %d\n", ump->uncommitted_lbs[vpart_num]));
1102 1.1.2.5 yamt
1103 1.1.2.5 yamt /* sanity */
1104 1.1.2.5 yamt if (ump->uncommitted_lbs[vpart_num] < 0)
1105 1.1.2.5 yamt ump->uncommitted_lbs[vpart_num] = 0;
1106 1.1.2.5 yamt
1107 1.1.2.5 yamt mutex_exit(&ump->allocate_mutex);
1108 1.1.2.5 yamt }
1109 1.1.2.5 yamt
1110 1.1.2.5 yamt /* --------------------------------------------------------------------- */
1111 1.1.2.5 yamt
1112 1.1.2.5 yamt /*
1113 1.1.2.5 yamt * Allocate an extent of given length on given virt. partition. It doesn't
1114 1.1.2.5 yamt * have to be one stretch.
1115 1.1.2.5 yamt */
1116 1.1.2.5 yamt
1117 1.1.2.5 yamt int
1118 1.1.2.5 yamt udf_allocate_space(struct udf_mount *ump, struct udf_node *udf_node,
1119 1.1.2.5 yamt int udf_c_type, uint16_t vpart_num, uint32_t num_lb, uint64_t *lmapping)
1120 1.1.2.2 yamt {
1121 1.1.2.2 yamt struct mmc_trackinfo *alloc_track, *other_track;
1122 1.1.2.2 yamt struct udf_bitmap *bitmap;
1123 1.1.2.2 yamt struct part_desc *pdesc;
1124 1.1.2.2 yamt struct logvol_int_desc *lvid;
1125 1.1.2.3 yamt uint64_t *lmappos;
1126 1.1.2.2 yamt uint32_t ptov, lb_num, *freepos, free_lbs;
1127 1.1.2.2 yamt int lb_size, alloc_num_lb;
1128 1.1.2.3 yamt int alloc_type, error;
1129 1.1.2.3 yamt int is_node;
1130 1.1.2.2 yamt
1131 1.1.2.3 yamt DPRINTF(CALL, ("udf_allocate_space(ctype %d, vpart %d, num_lb %d\n",
1132 1.1.2.3 yamt udf_c_type, vpart_num, num_lb));
1133 1.1.2.2 yamt mutex_enter(&ump->allocate_mutex);
1134 1.1.2.3 yamt
1135 1.1.2.2 yamt lb_size = udf_rw32(ump->logical_vol->lb_size);
1136 1.1.2.2 yamt KASSERT(lb_size == ump->discinfo.sector_size);
1137 1.1.2.2 yamt
1138 1.1.2.3 yamt alloc_type = ump->vtop_alloc[vpart_num];
1139 1.1.2.3 yamt is_node = (udf_c_type == UDF_C_NODE);
1140 1.1.2.2 yamt
1141 1.1.2.2 yamt lmappos = lmapping;
1142 1.1.2.3 yamt error = 0;
1143 1.1.2.2 yamt switch (alloc_type) {
1144 1.1.2.2 yamt case UDF_ALLOC_VAT :
1145 1.1.2.2 yamt /* search empty slot in VAT file */
1146 1.1.2.2 yamt KASSERT(num_lb == 1);
1147 1.1.2.2 yamt error = udf_search_free_vatloc(ump, &lb_num);
1148 1.1.2.5 yamt if (!error) {
1149 1.1.2.2 yamt *lmappos = lb_num;
1150 1.1.2.5 yamt
1151 1.1.2.5 yamt /* reserve on the backing sequential partition since
1152 1.1.2.5 yamt * that partition is credited back later */
1153 1.1.2.5 yamt udf_do_reserve_space(ump, udf_node,
1154 1.1.2.5 yamt ump->vtop[vpart_num], num_lb);
1155 1.1.2.5 yamt }
1156 1.1.2.2 yamt break;
1157 1.1.2.2 yamt case UDF_ALLOC_SEQUENTIAL :
1158 1.1.2.2 yamt /* sequential allocation on recordable media */
1159 1.1.2.3 yamt /* get partition backing up this vpart_num_num */
1160 1.1.2.3 yamt pdesc = ump->partitions[ump->vtop[vpart_num]];
1161 1.1.2.3 yamt
1162 1.1.2.2 yamt /* calculate offset from physical base partition */
1163 1.1.2.2 yamt ptov = udf_rw32(pdesc->start_loc);
1164 1.1.2.2 yamt
1165 1.1.2.3 yamt /* get our track descriptors */
1166 1.1.2.3 yamt if (vpart_num == ump->node_part) {
1167 1.1.2.3 yamt alloc_track = &ump->metadata_track;
1168 1.1.2.3 yamt other_track = &ump->data_track;
1169 1.1.2.3 yamt } else {
1170 1.1.2.3 yamt alloc_track = &ump->data_track;
1171 1.1.2.3 yamt other_track = &ump->metadata_track;
1172 1.1.2.3 yamt }
1173 1.1.2.3 yamt
1174 1.1.2.3 yamt /* allocate */
1175 1.1.2.2 yamt for (lb_num = 0; lb_num < num_lb; lb_num++) {
1176 1.1.2.2 yamt *lmappos++ = alloc_track->next_writable - ptov;
1177 1.1.2.2 yamt alloc_track->next_writable++;
1178 1.1.2.2 yamt alloc_track->free_blocks--;
1179 1.1.2.2 yamt }
1180 1.1.2.3 yamt
1181 1.1.2.3 yamt /* keep other track up-to-date */
1182 1.1.2.2 yamt if (alloc_track->tracknr == other_track->tracknr)
1183 1.1.2.2 yamt memcpy(other_track, alloc_track,
1184 1.1.2.2 yamt sizeof(struct mmc_trackinfo));
1185 1.1.2.2 yamt break;
1186 1.1.2.2 yamt case UDF_ALLOC_SPACEMAP :
1187 1.1.2.3 yamt /* try to allocate on unallocated bits */
1188 1.1.2.2 yamt alloc_num_lb = num_lb;
1189 1.1.2.3 yamt bitmap = &ump->part_unalloc_bits[vpart_num];
1190 1.1.2.3 yamt udf_bitmap_allocate(bitmap, is_node, &alloc_num_lb, lmappos);
1191 1.1.2.2 yamt ump->lvclose |= UDF_WRITE_PART_BITMAPS;
1192 1.1.2.3 yamt
1193 1.1.2.3 yamt /* have we allocated all? */
1194 1.1.2.2 yamt if (alloc_num_lb) {
1195 1.1.2.2 yamt /* TODO convert freed to unalloc and try again */
1196 1.1.2.2 yamt /* free allocated piece for now */
1197 1.1.2.2 yamt lmappos = lmapping;
1198 1.1.2.2 yamt for (lb_num=0; lb_num < num_lb-alloc_num_lb; lb_num++) {
1199 1.1.2.2 yamt udf_bitmap_free(bitmap, *lmappos++, 1);
1200 1.1.2.2 yamt }
1201 1.1.2.2 yamt error = ENOSPC;
1202 1.1.2.2 yamt }
1203 1.1.2.2 yamt if (!error) {
1204 1.1.2.2 yamt /* adjust freecount */
1205 1.1.2.2 yamt lvid = ump->logvol_integrity;
1206 1.1.2.3 yamt freepos = &lvid->tables[0] + vpart_num;
1207 1.1.2.3 yamt free_lbs = udf_rw32(*freepos);
1208 1.1.2.3 yamt *freepos = udf_rw32(free_lbs - num_lb);
1209 1.1.2.3 yamt }
1210 1.1.2.3 yamt break;
1211 1.1.2.3 yamt case UDF_ALLOC_METABITMAP : /* UDF 2.50, 2.60 BluRay-RE */
1212 1.1.2.3 yamt /* allocate on metadata unallocated bits */
1213 1.1.2.3 yamt alloc_num_lb = num_lb;
1214 1.1.2.3 yamt bitmap = &ump->metadata_unalloc_bits;
1215 1.1.2.3 yamt udf_bitmap_allocate(bitmap, is_node, &alloc_num_lb, lmappos);
1216 1.1.2.3 yamt ump->lvclose |= UDF_WRITE_PART_BITMAPS;
1217 1.1.2.3 yamt
1218 1.1.2.3 yamt /* have we allocated all? */
1219 1.1.2.3 yamt if (alloc_num_lb) {
1220 1.1.2.3 yamt /* YIKES! TODO we need to extend the metadata partition */
1221 1.1.2.3 yamt /* free allocated piece for now */
1222 1.1.2.3 yamt lmappos = lmapping;
1223 1.1.2.3 yamt for (lb_num=0; lb_num < num_lb-alloc_num_lb; lb_num++) {
1224 1.1.2.3 yamt udf_bitmap_free(bitmap, *lmappos++, 1);
1225 1.1.2.3 yamt }
1226 1.1.2.3 yamt error = ENOSPC;
1227 1.1.2.3 yamt }
1228 1.1.2.3 yamt if (!error) {
1229 1.1.2.3 yamt /* adjust freecount */
1230 1.1.2.3 yamt lvid = ump->logvol_integrity;
1231 1.1.2.3 yamt freepos = &lvid->tables[0] + vpart_num;
1232 1.1.2.2 yamt free_lbs = udf_rw32(*freepos);
1233 1.1.2.2 yamt *freepos = udf_rw32(free_lbs - num_lb);
1234 1.1.2.2 yamt }
1235 1.1.2.2 yamt break;
1236 1.1.2.3 yamt case UDF_ALLOC_METASEQUENTIAL : /* UDF 2.60 BluRay-R */
1237 1.1.2.3 yamt case UDF_ALLOC_RELAXEDSEQUENTIAL : /* UDF 2.50/~meta BluRay-R */
1238 1.1.2.2 yamt printf("ALERT: udf_allocate_space : allocation %d "
1239 1.1.2.2 yamt "not implemented yet!\n", alloc_type);
1240 1.1.2.2 yamt /* TODO implement, doesn't have to be contiguous */
1241 1.1.2.2 yamt error = ENOSPC;
1242 1.1.2.2 yamt break;
1243 1.1.2.2 yamt }
1244 1.1.2.2 yamt
1245 1.1.2.5 yamt if (!error) {
1246 1.1.2.5 yamt /* credit our partition since we have committed the space */
1247 1.1.2.5 yamt udf_do_unreserve_space(ump, udf_node, vpart_num, num_lb);
1248 1.1.2.5 yamt }
1249 1.1.2.5 yamt
1250 1.1.2.2 yamt #ifdef DEBUG
1251 1.1.2.2 yamt if (udf_verbose & UDF_DEBUG_ALLOC) {
1252 1.1.2.2 yamt lmappos = lmapping;
1253 1.1.2.3 yamt printf("udf_allocate_space, allocated logical lba :\n");
1254 1.1.2.2 yamt for (lb_num = 0; lb_num < num_lb; lb_num++) {
1255 1.1.2.5 yamt printf("%s %"PRIu64, (lb_num > 0)?",":"",
1256 1.1.2.3 yamt *lmappos++);
1257 1.1.2.2 yamt }
1258 1.1.2.3 yamt printf("\n");
1259 1.1.2.2 yamt }
1260 1.1.2.2 yamt #endif
1261 1.1.2.2 yamt mutex_exit(&ump->allocate_mutex);
1262 1.1.2.2 yamt
1263 1.1.2.2 yamt return error;
1264 1.1.2.2 yamt }
1265 1.1.2.2 yamt
1266 1.1.2.2 yamt /* --------------------------------------------------------------------- */
1267 1.1.2.2 yamt
1268 1.1.2.2 yamt void
1269 1.1.2.2 yamt udf_free_allocated_space(struct udf_mount *ump, uint32_t lb_num,
1270 1.1.2.2 yamt uint16_t vpart_num, uint32_t num_lb)
1271 1.1.2.2 yamt {
1272 1.1.2.2 yamt struct udf_bitmap *bitmap;
1273 1.1.2.2 yamt struct part_desc *pdesc;
1274 1.1.2.2 yamt struct logvol_int_desc *lvid;
1275 1.1.2.2 yamt uint32_t ptov, lb_map, udf_rw32_lbmap;
1276 1.1.2.2 yamt uint32_t *freepos, free_lbs;
1277 1.1.2.2 yamt int phys_part;
1278 1.1.2.2 yamt int error;
1279 1.1.2.2 yamt
1280 1.1.2.2 yamt DPRINTF(ALLOC, ("udf_free_allocated_space: freeing virt lbnum %d "
1281 1.1.2.2 yamt "part %d + %d sect\n", lb_num, vpart_num, num_lb));
1282 1.1.2.2 yamt
1283 1.1.2.3 yamt /* no use freeing zero length */
1284 1.1.2.3 yamt if (num_lb == 0)
1285 1.1.2.3 yamt return;
1286 1.1.2.3 yamt
1287 1.1.2.2 yamt mutex_enter(&ump->allocate_mutex);
1288 1.1.2.2 yamt
1289 1.1.2.2 yamt /* get partition backing up this vpart_num */
1290 1.1.2.2 yamt pdesc = ump->partitions[ump->vtop[vpart_num]];
1291 1.1.2.2 yamt
1292 1.1.2.2 yamt switch (ump->vtop_tp[vpart_num]) {
1293 1.1.2.2 yamt case UDF_VTOP_TYPE_PHYS :
1294 1.1.2.2 yamt case UDF_VTOP_TYPE_SPARABLE :
1295 1.1.2.2 yamt /* free space to freed or unallocated space bitmap */
1296 1.1.2.2 yamt ptov = udf_rw32(pdesc->start_loc);
1297 1.1.2.2 yamt phys_part = ump->vtop[vpart_num];
1298 1.1.2.2 yamt
1299 1.1.2.2 yamt /* first try freed space bitmap */
1300 1.1.2.2 yamt bitmap = &ump->part_freed_bits[phys_part];
1301 1.1.2.2 yamt
1302 1.1.2.2 yamt /* if not defined, use unallocated bitmap */
1303 1.1.2.2 yamt if (bitmap->bits == NULL)
1304 1.1.2.2 yamt bitmap = &ump->part_unalloc_bits[phys_part];
1305 1.1.2.2 yamt
1306 1.1.2.3 yamt /* if no bitmaps are defined, bail out; XXX OK? */
1307 1.1.2.2 yamt if (bitmap->bits == NULL)
1308 1.1.2.2 yamt break;
1309 1.1.2.2 yamt
1310 1.1.2.2 yamt /* free bits if its defined */
1311 1.1.2.2 yamt KASSERT(bitmap->bits);
1312 1.1.2.2 yamt ump->lvclose |= UDF_WRITE_PART_BITMAPS;
1313 1.1.2.2 yamt udf_bitmap_free(bitmap, lb_num, num_lb);
1314 1.1.2.2 yamt
1315 1.1.2.2 yamt /* adjust freecount */
1316 1.1.2.2 yamt lvid = ump->logvol_integrity;
1317 1.1.2.2 yamt freepos = &lvid->tables[0] + vpart_num;
1318 1.1.2.2 yamt free_lbs = udf_rw32(*freepos);
1319 1.1.2.2 yamt *freepos = udf_rw32(free_lbs + num_lb);
1320 1.1.2.2 yamt break;
1321 1.1.2.2 yamt case UDF_VTOP_TYPE_VIRT :
1322 1.1.2.2 yamt /* free this VAT entry */
1323 1.1.2.2 yamt KASSERT(num_lb == 1);
1324 1.1.2.2 yamt
1325 1.1.2.2 yamt lb_map = 0xffffffff;
1326 1.1.2.2 yamt udf_rw32_lbmap = udf_rw32(lb_map);
1327 1.1.2.2 yamt error = udf_vat_write(ump->vat_node,
1328 1.1.2.2 yamt (uint8_t *) &udf_rw32_lbmap, 4,
1329 1.1.2.2 yamt ump->vat_offset + lb_num * 4);
1330 1.1.2.2 yamt KASSERT(error == 0);
1331 1.1.2.2 yamt ump->vat_last_free_lb = MIN(ump->vat_last_free_lb, lb_num);
1332 1.1.2.2 yamt break;
1333 1.1.2.2 yamt case UDF_VTOP_TYPE_META :
1334 1.1.2.2 yamt /* free space in the metadata bitmap */
1335 1.1.2.3 yamt bitmap = &ump->metadata_unalloc_bits;
1336 1.1.2.3 yamt KASSERT(bitmap->bits);
1337 1.1.2.3 yamt
1338 1.1.2.3 yamt ump->lvclose |= UDF_WRITE_PART_BITMAPS;
1339 1.1.2.3 yamt udf_bitmap_free(bitmap, lb_num, num_lb);
1340 1.1.2.3 yamt
1341 1.1.2.3 yamt /* adjust freecount */
1342 1.1.2.3 yamt lvid = ump->logvol_integrity;
1343 1.1.2.3 yamt freepos = &lvid->tables[0] + vpart_num;
1344 1.1.2.3 yamt free_lbs = udf_rw32(*freepos);
1345 1.1.2.3 yamt *freepos = udf_rw32(free_lbs + num_lb);
1346 1.1.2.3 yamt break;
1347 1.1.2.2 yamt default:
1348 1.1.2.2 yamt printf("ALERT: udf_free_allocated_space : allocation %d "
1349 1.1.2.2 yamt "not implemented yet!\n", ump->vtop_tp[vpart_num]);
1350 1.1.2.2 yamt break;
1351 1.1.2.2 yamt }
1352 1.1.2.2 yamt
1353 1.1.2.2 yamt mutex_exit(&ump->allocate_mutex);
1354 1.1.2.2 yamt }
1355 1.1.2.2 yamt
1356 1.1.2.2 yamt /* --------------------------------------------------------------------- */
1357 1.1.2.2 yamt
1358 1.1.2.2 yamt /*
1359 1.1.2.2 yamt * Allocate a buf on disc for direct write out. The space doesn't have to be
1360 1.1.2.2 yamt * contiguous as the caller takes care of this.
1361 1.1.2.2 yamt */
1362 1.1.2.2 yamt
1363 1.1.2.2 yamt void
1364 1.1.2.2 yamt udf_late_allocate_buf(struct udf_mount *ump, struct buf *buf,
1365 1.1.2.3 yamt uint64_t *lmapping, struct long_ad *node_ad_cpy, uint16_t *vpart_nump)
1366 1.1.2.2 yamt {
1367 1.1.2.2 yamt struct udf_node *udf_node = VTOI(buf->b_vp);
1368 1.1.2.2 yamt int lb_size, blks, udf_c_type;
1369 1.1.2.3 yamt int vpart_num, num_lb;
1370 1.1.2.2 yamt int error, s;
1371 1.1.2.2 yamt
1372 1.1.2.2 yamt /*
1373 1.1.2.2 yamt * for each sector in the buf, allocate a sector on disc and record
1374 1.1.2.2 yamt * its position in the provided mapping array.
1375 1.1.2.2 yamt *
1376 1.1.2.2 yamt * If its userdata or FIDs, record its location in its node.
1377 1.1.2.2 yamt */
1378 1.1.2.2 yamt
1379 1.1.2.2 yamt lb_size = udf_rw32(ump->logical_vol->lb_size);
1380 1.1.2.2 yamt num_lb = (buf->b_bcount + lb_size -1) / lb_size;
1381 1.1.2.2 yamt blks = lb_size / DEV_BSIZE;
1382 1.1.2.2 yamt udf_c_type = buf->b_udf_c_type;
1383 1.1.2.2 yamt
1384 1.1.2.2 yamt KASSERT(lb_size == ump->discinfo.sector_size);
1385 1.1.2.2 yamt
1386 1.1.2.3 yamt /* select partition to record the buffer on */
1387 1.1.2.5 yamt vpart_num = *vpart_nump = udf_get_record_vpart(ump, udf_c_type);
1388 1.1.2.2 yamt
1389 1.1.2.2 yamt if (udf_c_type == UDF_C_NODE) {
1390 1.1.2.2 yamt /* if not VAT, its allready allocated */
1391 1.1.2.3 yamt if (ump->vtop_alloc[ump->node_part] != UDF_ALLOC_VAT)
1392 1.1.2.2 yamt return;
1393 1.1.2.2 yamt
1394 1.1.2.3 yamt /* allocate on its backing sequential partition */
1395 1.1.2.3 yamt vpart_num = ump->data_part;
1396 1.1.2.2 yamt }
1397 1.1.2.2 yamt
1398 1.1.2.5 yamt /* XXX can this still happen? */
1399 1.1.2.3 yamt /* do allocation on the selected partition */
1400 1.1.2.5 yamt error = udf_allocate_space(ump, udf_node, udf_c_type,
1401 1.1.2.3 yamt vpart_num, num_lb, lmapping);
1402 1.1.2.2 yamt if (error) {
1403 1.1.2.5 yamt /*
1404 1.1.2.5 yamt * ARGH! we haven't done our accounting right! it should
1405 1.1.2.5 yamt * allways succeed.
1406 1.1.2.5 yamt */
1407 1.1.2.2 yamt panic("UDF disc allocation accounting gone wrong");
1408 1.1.2.2 yamt }
1409 1.1.2.2 yamt
1410 1.1.2.2 yamt /* If its userdata or FIDs, record its allocation in its node. */
1411 1.1.2.3 yamt if ((udf_c_type == UDF_C_USERDATA) ||
1412 1.1.2.3 yamt (udf_c_type == UDF_C_FIDS) ||
1413 1.1.2.3 yamt (udf_c_type == UDF_C_METADATA_SBM))
1414 1.1.2.3 yamt {
1415 1.1.2.2 yamt udf_record_allocation_in_node(ump, buf, vpart_num, lmapping,
1416 1.1.2.2 yamt node_ad_cpy);
1417 1.1.2.2 yamt /* decrement our outstanding bufs counter */
1418 1.1.2.2 yamt s = splbio();
1419 1.1.2.2 yamt udf_node->outstanding_bufs--;
1420 1.1.2.2 yamt splx(s);
1421 1.1.2.2 yamt }
1422 1.1.2.2 yamt }
1423 1.1.2.2 yamt
1424 1.1.2.2 yamt /* --------------------------------------------------------------------- */
1425 1.1.2.2 yamt
1426 1.1.2.2 yamt /*
1427 1.1.2.2 yamt * Try to merge a1 with the new piece a2. udf_ads_merge returns error when not
1428 1.1.2.2 yamt * possible (anymore); a2 returns the rest piece.
1429 1.1.2.2 yamt */
1430 1.1.2.2 yamt
1431 1.1.2.2 yamt static int
1432 1.1.2.2 yamt udf_ads_merge(uint32_t lb_size, struct long_ad *a1, struct long_ad *a2)
1433 1.1.2.2 yamt {
1434 1.1.2.2 yamt uint32_t max_len, merge_len;
1435 1.1.2.2 yamt uint32_t a1_len, a2_len;
1436 1.1.2.2 yamt uint32_t a1_flags, a2_flags;
1437 1.1.2.2 yamt uint32_t a1_lbnum, a2_lbnum;
1438 1.1.2.2 yamt uint16_t a1_part, a2_part;
1439 1.1.2.2 yamt
1440 1.1.2.2 yamt max_len = ((UDF_EXT_MAXLEN / lb_size) * lb_size);
1441 1.1.2.2 yamt
1442 1.1.2.2 yamt a1_flags = UDF_EXT_FLAGS(udf_rw32(a1->len));
1443 1.1.2.2 yamt a1_len = UDF_EXT_LEN(udf_rw32(a1->len));
1444 1.1.2.2 yamt a1_lbnum = udf_rw32(a1->loc.lb_num);
1445 1.1.2.2 yamt a1_part = udf_rw16(a1->loc.part_num);
1446 1.1.2.2 yamt
1447 1.1.2.2 yamt a2_flags = UDF_EXT_FLAGS(udf_rw32(a2->len));
1448 1.1.2.2 yamt a2_len = UDF_EXT_LEN(udf_rw32(a2->len));
1449 1.1.2.2 yamt a2_lbnum = udf_rw32(a2->loc.lb_num);
1450 1.1.2.2 yamt a2_part = udf_rw16(a2->loc.part_num);
1451 1.1.2.2 yamt
1452 1.1.2.2 yamt /* defines same space */
1453 1.1.2.2 yamt if (a1_flags != a2_flags)
1454 1.1.2.2 yamt return 1;
1455 1.1.2.2 yamt
1456 1.1.2.2 yamt if (a1_flags != UDF_EXT_FREE) {
1457 1.1.2.2 yamt /* the same partition */
1458 1.1.2.2 yamt if (a1_part != a2_part)
1459 1.1.2.2 yamt return 1;
1460 1.1.2.2 yamt
1461 1.1.2.2 yamt /* a2 is successor of a1 */
1462 1.1.2.2 yamt if (a1_lbnum * lb_size + a1_len != a2_lbnum * lb_size)
1463 1.1.2.2 yamt return 1;
1464 1.1.2.2 yamt }
1465 1.1.2.3 yamt
1466 1.1.2.2 yamt /* merge as most from a2 if possible */
1467 1.1.2.2 yamt merge_len = MIN(a2_len, max_len - a1_len);
1468 1.1.2.2 yamt a1_len += merge_len;
1469 1.1.2.2 yamt a2_len -= merge_len;
1470 1.1.2.2 yamt a2_lbnum += merge_len/lb_size;
1471 1.1.2.2 yamt
1472 1.1.2.2 yamt a1->len = udf_rw32(a1_len | a1_flags);
1473 1.1.2.2 yamt a2->len = udf_rw32(a2_len | a2_flags);
1474 1.1.2.2 yamt a2->loc.lb_num = udf_rw32(a2_lbnum);
1475 1.1.2.2 yamt
1476 1.1.2.2 yamt if (a2_len > 0)
1477 1.1.2.2 yamt return 1;
1478 1.1.2.2 yamt
1479 1.1.2.2 yamt /* there is space over to merge */
1480 1.1.2.2 yamt return 0;
1481 1.1.2.2 yamt }
1482 1.1.2.2 yamt
1483 1.1.2.2 yamt /* --------------------------------------------------------------------- */
1484 1.1.2.2 yamt
1485 1.1.2.2 yamt static void
1486 1.1.2.2 yamt udf_wipe_adslots(struct udf_node *udf_node)
1487 1.1.2.2 yamt {
1488 1.1.2.2 yamt struct file_entry *fe;
1489 1.1.2.2 yamt struct extfile_entry *efe;
1490 1.1.2.2 yamt struct alloc_ext_entry *ext;
1491 1.1.2.2 yamt uint64_t inflen, objsize;
1492 1.1.2.2 yamt uint32_t lb_size, dscr_size, l_ea, l_ad, max_l_ad, crclen;
1493 1.1.2.2 yamt uint8_t *data_pos;
1494 1.1.2.2 yamt int extnr;
1495 1.1.2.2 yamt
1496 1.1.2.2 yamt lb_size = udf_rw32(udf_node->ump->logical_vol->lb_size);
1497 1.1.2.2 yamt
1498 1.1.2.2 yamt fe = udf_node->fe;
1499 1.1.2.2 yamt efe = udf_node->efe;
1500 1.1.2.2 yamt if (fe) {
1501 1.1.2.2 yamt inflen = udf_rw64(fe->inf_len);
1502 1.1.2.2 yamt objsize = inflen;
1503 1.1.2.2 yamt dscr_size = sizeof(struct file_entry) -1;
1504 1.1.2.2 yamt l_ea = udf_rw32(fe->l_ea);
1505 1.1.2.2 yamt l_ad = udf_rw32(fe->l_ad);
1506 1.1.2.2 yamt data_pos = (uint8_t *) fe + dscr_size + l_ea;
1507 1.1.2.2 yamt } else {
1508 1.1.2.2 yamt inflen = udf_rw64(efe->inf_len);
1509 1.1.2.2 yamt objsize = udf_rw64(efe->obj_size);
1510 1.1.2.2 yamt dscr_size = sizeof(struct extfile_entry) -1;
1511 1.1.2.2 yamt l_ea = udf_rw32(efe->l_ea);
1512 1.1.2.2 yamt l_ad = udf_rw32(efe->l_ad);
1513 1.1.2.2 yamt data_pos = (uint8_t *) efe + dscr_size + l_ea;
1514 1.1.2.2 yamt }
1515 1.1.2.2 yamt max_l_ad = lb_size - dscr_size - l_ea;
1516 1.1.2.2 yamt
1517 1.1.2.2 yamt /* wipe fe/efe */
1518 1.1.2.2 yamt memset(data_pos, 0, max_l_ad);
1519 1.1.2.2 yamt crclen = dscr_size - UDF_DESC_TAG_LENGTH + l_ea;
1520 1.1.2.2 yamt if (fe) {
1521 1.1.2.2 yamt fe->l_ad = udf_rw32(0);
1522 1.1.2.2 yamt fe->logblks_rec = udf_rw64(0);
1523 1.1.2.4 yamt fe->tag.desc_crc_len = udf_rw16(crclen);
1524 1.1.2.2 yamt } else {
1525 1.1.2.2 yamt efe->l_ad = udf_rw32(0);
1526 1.1.2.2 yamt efe->logblks_rec = udf_rw64(0);
1527 1.1.2.4 yamt efe->tag.desc_crc_len = udf_rw16(crclen);
1528 1.1.2.2 yamt }
1529 1.1.2.2 yamt
1530 1.1.2.2 yamt /* wipe all allocation extent entries */
1531 1.1.2.2 yamt for (extnr = 0; extnr < udf_node->num_extensions; extnr++) {
1532 1.1.2.2 yamt ext = udf_node->ext[extnr];
1533 1.1.2.2 yamt dscr_size = sizeof(struct alloc_ext_entry) -1;
1534 1.1.2.3 yamt data_pos = (uint8_t *) ext->data;
1535 1.1.2.2 yamt max_l_ad = lb_size - dscr_size;
1536 1.1.2.2 yamt memset(data_pos, 0, max_l_ad);
1537 1.1.2.2 yamt ext->l_ad = udf_rw32(0);
1538 1.1.2.2 yamt
1539 1.1.2.2 yamt crclen = dscr_size - UDF_DESC_TAG_LENGTH;
1540 1.1.2.4 yamt ext->tag.desc_crc_len = udf_rw16(crclen);
1541 1.1.2.2 yamt }
1542 1.1.2.3 yamt udf_node->i_flags |= IN_NODE_REBUILD;
1543 1.1.2.2 yamt }
1544 1.1.2.2 yamt
1545 1.1.2.2 yamt /* --------------------------------------------------------------------- */
1546 1.1.2.2 yamt
1547 1.1.2.2 yamt void
1548 1.1.2.2 yamt udf_get_adslot(struct udf_node *udf_node, int slot, struct long_ad *icb,
1549 1.1.2.2 yamt int *eof) {
1550 1.1.2.2 yamt struct file_entry *fe;
1551 1.1.2.2 yamt struct extfile_entry *efe;
1552 1.1.2.2 yamt struct alloc_ext_entry *ext;
1553 1.1.2.2 yamt struct icb_tag *icbtag;
1554 1.1.2.2 yamt struct short_ad *short_ad;
1555 1.1.2.3 yamt struct long_ad *long_ad, l_icb;
1556 1.1.2.2 yamt uint32_t offset;
1557 1.1.2.3 yamt uint32_t lb_size, dscr_size, l_ea, l_ad, flags;
1558 1.1.2.2 yamt uint8_t *data_pos;
1559 1.1.2.2 yamt int icbflags, addr_type, adlen, extnr;
1560 1.1.2.2 yamt
1561 1.1.2.2 yamt /* determine what descriptor we are in */
1562 1.1.2.2 yamt lb_size = udf_rw32(udf_node->ump->logical_vol->lb_size);
1563 1.1.2.2 yamt
1564 1.1.2.2 yamt fe = udf_node->fe;
1565 1.1.2.2 yamt efe = udf_node->efe;
1566 1.1.2.2 yamt if (fe) {
1567 1.1.2.2 yamt icbtag = &fe->icbtag;
1568 1.1.2.2 yamt dscr_size = sizeof(struct file_entry) -1;
1569 1.1.2.2 yamt l_ea = udf_rw32(fe->l_ea);
1570 1.1.2.2 yamt l_ad = udf_rw32(fe->l_ad);
1571 1.1.2.2 yamt data_pos = (uint8_t *) fe + dscr_size + l_ea;
1572 1.1.2.2 yamt } else {
1573 1.1.2.2 yamt icbtag = &efe->icbtag;
1574 1.1.2.2 yamt dscr_size = sizeof(struct extfile_entry) -1;
1575 1.1.2.2 yamt l_ea = udf_rw32(efe->l_ea);
1576 1.1.2.2 yamt l_ad = udf_rw32(efe->l_ad);
1577 1.1.2.2 yamt data_pos = (uint8_t *) efe + dscr_size + l_ea;
1578 1.1.2.2 yamt }
1579 1.1.2.2 yamt
1580 1.1.2.2 yamt icbflags = udf_rw16(icbtag->flags);
1581 1.1.2.2 yamt addr_type = icbflags & UDF_ICB_TAG_FLAGS_ALLOC_MASK;
1582 1.1.2.2 yamt
1583 1.1.2.2 yamt /* just in case we're called on an intern, its EOF */
1584 1.1.2.2 yamt if (addr_type == UDF_ICB_INTERN_ALLOC) {
1585 1.1.2.2 yamt memset(icb, 0, sizeof(struct long_ad));
1586 1.1.2.2 yamt *eof = 1;
1587 1.1.2.2 yamt return;
1588 1.1.2.2 yamt }
1589 1.1.2.2 yamt
1590 1.1.2.2 yamt adlen = 0;
1591 1.1.2.2 yamt if (addr_type == UDF_ICB_SHORT_ALLOC) {
1592 1.1.2.2 yamt adlen = sizeof(struct short_ad);
1593 1.1.2.2 yamt } else if (addr_type == UDF_ICB_LONG_ALLOC) {
1594 1.1.2.2 yamt adlen = sizeof(struct long_ad);
1595 1.1.2.2 yamt }
1596 1.1.2.2 yamt
1597 1.1.2.2 yamt /* if offset too big, we go to the allocation extensions */
1598 1.1.2.2 yamt offset = slot * adlen;
1599 1.1.2.3 yamt extnr = -1;
1600 1.1.2.3 yamt while (offset >= l_ad) {
1601 1.1.2.3 yamt /* check if our last entry is a redirect */
1602 1.1.2.3 yamt if (addr_type == UDF_ICB_SHORT_ALLOC) {
1603 1.1.2.3 yamt short_ad = (struct short_ad *) (data_pos + l_ad-adlen);
1604 1.1.2.3 yamt l_icb.len = short_ad->len;
1605 1.1.2.3 yamt l_icb.loc.part_num = udf_node->loc.loc.part_num;
1606 1.1.2.3 yamt l_icb.loc.lb_num = short_ad->lb_num;
1607 1.1.2.3 yamt } else {
1608 1.1.2.3 yamt KASSERT(addr_type == UDF_ICB_LONG_ALLOC);
1609 1.1.2.3 yamt long_ad = (struct long_ad *) (data_pos + l_ad-adlen);
1610 1.1.2.3 yamt l_icb = *long_ad;
1611 1.1.2.3 yamt }
1612 1.1.2.3 yamt flags = UDF_EXT_FLAGS(udf_rw32(l_icb.len));
1613 1.1.2.3 yamt if (flags != UDF_EXT_REDIRECT) {
1614 1.1.2.3 yamt l_ad = 0; /* force EOF */
1615 1.1.2.3 yamt break;
1616 1.1.2.3 yamt }
1617 1.1.2.3 yamt
1618 1.1.2.3 yamt /* advance to next extent */
1619 1.1.2.2 yamt extnr++;
1620 1.1.2.3 yamt if (extnr >= udf_node->num_extensions) {
1621 1.1.2.2 yamt l_ad = 0; /* force EOF */
1622 1.1.2.2 yamt break;
1623 1.1.2.2 yamt }
1624 1.1.2.3 yamt offset = offset - l_ad;
1625 1.1.2.3 yamt ext = udf_node->ext[extnr];
1626 1.1.2.3 yamt dscr_size = sizeof(struct alloc_ext_entry) -1;
1627 1.1.2.3 yamt l_ad = udf_rw32(ext->l_ad);
1628 1.1.2.3 yamt data_pos = (uint8_t *) ext + dscr_size;
1629 1.1.2.2 yamt }
1630 1.1.2.2 yamt
1631 1.1.2.3 yamt /* XXX l_ad == 0 should be enough to check */
1632 1.1.2.2 yamt *eof = (offset >= l_ad) || (l_ad == 0);
1633 1.1.2.2 yamt if (*eof) {
1634 1.1.2.3 yamt DPRINTF(PARANOIDADWLK, ("returning EOF, extnr %d, offset %d, "
1635 1.1.2.3 yamt "l_ad %d\n", extnr, offset, l_ad));
1636 1.1.2.2 yamt memset(icb, 0, sizeof(struct long_ad));
1637 1.1.2.2 yamt return;
1638 1.1.2.2 yamt }
1639 1.1.2.2 yamt
1640 1.1.2.2 yamt /* get the element */
1641 1.1.2.2 yamt if (addr_type == UDF_ICB_SHORT_ALLOC) {
1642 1.1.2.2 yamt short_ad = (struct short_ad *) (data_pos + offset);
1643 1.1.2.2 yamt icb->len = short_ad->len;
1644 1.1.2.3 yamt icb->loc.part_num = udf_node->loc.loc.part_num;
1645 1.1.2.2 yamt icb->loc.lb_num = short_ad->lb_num;
1646 1.1.2.2 yamt } else if (addr_type == UDF_ICB_LONG_ALLOC) {
1647 1.1.2.2 yamt long_ad = (struct long_ad *) (data_pos + offset);
1648 1.1.2.2 yamt *icb = *long_ad;
1649 1.1.2.2 yamt }
1650 1.1.2.3 yamt DPRINTF(PARANOIDADWLK, ("returning element : v %d, lb %d, len %d, "
1651 1.1.2.3 yamt "flags %d\n", icb->loc.part_num, icb->loc.lb_num,
1652 1.1.2.3 yamt UDF_EXT_LEN(icb->len), UDF_EXT_FLAGS(icb->len)));
1653 1.1.2.2 yamt }
1654 1.1.2.2 yamt
1655 1.1.2.2 yamt /* --------------------------------------------------------------------- */
1656 1.1.2.2 yamt
1657 1.1.2.2 yamt int
1658 1.1.2.3 yamt udf_append_adslot(struct udf_node *udf_node, int *slot, struct long_ad *icb) {
1659 1.1.2.3 yamt struct udf_mount *ump = udf_node->ump;
1660 1.1.2.3 yamt union dscrptr *dscr, *extdscr;
1661 1.1.2.2 yamt struct file_entry *fe;
1662 1.1.2.2 yamt struct extfile_entry *efe;
1663 1.1.2.2 yamt struct alloc_ext_entry *ext;
1664 1.1.2.2 yamt struct icb_tag *icbtag;
1665 1.1.2.2 yamt struct short_ad *short_ad;
1666 1.1.2.3 yamt struct long_ad *long_ad, o_icb, l_icb;
1667 1.1.2.2 yamt uint64_t logblks_rec, *logblks_rec_p;
1668 1.1.2.3 yamt uint64_t lmapping;
1669 1.1.2.3 yamt uint32_t offset, rest, len, lb_num;
1670 1.1.2.2 yamt uint32_t lb_size, dscr_size, l_ea, l_ad, *l_ad_p, max_l_ad, crclen;
1671 1.1.2.3 yamt uint32_t flags;
1672 1.1.2.3 yamt uint16_t vpart_num;
1673 1.1.2.2 yamt uint8_t *data_pos;
1674 1.1.2.2 yamt int icbflags, addr_type, adlen, extnr;
1675 1.1.2.3 yamt int error;
1676 1.1.2.2 yamt
1677 1.1.2.3 yamt lb_size = udf_rw32(ump->logical_vol->lb_size);
1678 1.1.2.3 yamt vpart_num = udf_rw16(udf_node->loc.loc.part_num);
1679 1.1.2.2 yamt
1680 1.1.2.3 yamt /* determine what descriptor we are in */
1681 1.1.2.2 yamt fe = udf_node->fe;
1682 1.1.2.2 yamt efe = udf_node->efe;
1683 1.1.2.2 yamt if (fe) {
1684 1.1.2.2 yamt icbtag = &fe->icbtag;
1685 1.1.2.2 yamt dscr = (union dscrptr *) fe;
1686 1.1.2.2 yamt dscr_size = sizeof(struct file_entry) -1;
1687 1.1.2.2 yamt
1688 1.1.2.2 yamt l_ea = udf_rw32(fe->l_ea);
1689 1.1.2.2 yamt l_ad_p = &fe->l_ad;
1690 1.1.2.2 yamt logblks_rec_p = &fe->logblks_rec;
1691 1.1.2.2 yamt } else {
1692 1.1.2.2 yamt icbtag = &efe->icbtag;
1693 1.1.2.2 yamt dscr = (union dscrptr *) efe;
1694 1.1.2.2 yamt dscr_size = sizeof(struct extfile_entry) -1;
1695 1.1.2.2 yamt
1696 1.1.2.2 yamt l_ea = udf_rw32(efe->l_ea);
1697 1.1.2.2 yamt l_ad_p = &efe->l_ad;
1698 1.1.2.2 yamt logblks_rec_p = &efe->logblks_rec;
1699 1.1.2.2 yamt }
1700 1.1.2.2 yamt data_pos = (uint8_t *) dscr + dscr_size + l_ea;
1701 1.1.2.2 yamt max_l_ad = lb_size - dscr_size - l_ea;
1702 1.1.2.2 yamt
1703 1.1.2.2 yamt icbflags = udf_rw16(icbtag->flags);
1704 1.1.2.2 yamt addr_type = icbflags & UDF_ICB_TAG_FLAGS_ALLOC_MASK;
1705 1.1.2.2 yamt
1706 1.1.2.2 yamt /* just in case we're called on an intern, its EOF */
1707 1.1.2.2 yamt if (addr_type == UDF_ICB_INTERN_ALLOC) {
1708 1.1.2.2 yamt panic("udf_append_adslot on UDF_ICB_INTERN_ALLOC\n");
1709 1.1.2.2 yamt }
1710 1.1.2.2 yamt
1711 1.1.2.2 yamt adlen = 0;
1712 1.1.2.2 yamt if (addr_type == UDF_ICB_SHORT_ALLOC) {
1713 1.1.2.2 yamt adlen = sizeof(struct short_ad);
1714 1.1.2.2 yamt } else if (addr_type == UDF_ICB_LONG_ALLOC) {
1715 1.1.2.2 yamt adlen = sizeof(struct long_ad);
1716 1.1.2.2 yamt }
1717 1.1.2.2 yamt
1718 1.1.2.3 yamt /* clean up given long_ad since it can be a synthesized one */
1719 1.1.2.3 yamt flags = UDF_EXT_FLAGS(udf_rw32(icb->len));
1720 1.1.2.3 yamt if (flags == UDF_EXT_FREE) {
1721 1.1.2.3 yamt icb->loc.part_num = udf_rw16(0);
1722 1.1.2.3 yamt icb->loc.lb_num = udf_rw32(0);
1723 1.1.2.3 yamt }
1724 1.1.2.3 yamt
1725 1.1.2.2 yamt /* if offset too big, we go to the allocation extensions */
1726 1.1.2.3 yamt l_ad = udf_rw32(*l_ad_p);
1727 1.1.2.3 yamt offset = (*slot) * adlen;
1728 1.1.2.3 yamt extnr = -1;
1729 1.1.2.3 yamt while (offset >= l_ad) {
1730 1.1.2.3 yamt /* check if our last entry is a redirect */
1731 1.1.2.3 yamt if (addr_type == UDF_ICB_SHORT_ALLOC) {
1732 1.1.2.3 yamt short_ad = (struct short_ad *) (data_pos + l_ad-adlen);
1733 1.1.2.3 yamt l_icb.len = short_ad->len;
1734 1.1.2.3 yamt l_icb.loc.part_num = udf_node->loc.loc.part_num;
1735 1.1.2.3 yamt l_icb.loc.lb_num = short_ad->lb_num;
1736 1.1.2.3 yamt } else {
1737 1.1.2.3 yamt KASSERT(addr_type == UDF_ICB_LONG_ALLOC);
1738 1.1.2.3 yamt long_ad = (struct long_ad *) (data_pos + l_ad-adlen);
1739 1.1.2.3 yamt l_icb = *long_ad;
1740 1.1.2.3 yamt }
1741 1.1.2.3 yamt flags = UDF_EXT_FLAGS(udf_rw32(l_icb.len));
1742 1.1.2.3 yamt if (flags != UDF_EXT_REDIRECT) {
1743 1.1.2.3 yamt /* only one past the last one is adressable */
1744 1.1.2.3 yamt break;
1745 1.1.2.3 yamt }
1746 1.1.2.3 yamt
1747 1.1.2.3 yamt /* advance to next extent */
1748 1.1.2.3 yamt extnr++;
1749 1.1.2.3 yamt KASSERT(extnr < udf_node->num_extensions);
1750 1.1.2.3 yamt offset = offset - l_ad;
1751 1.1.2.3 yamt
1752 1.1.2.2 yamt ext = udf_node->ext[extnr];
1753 1.1.2.2 yamt dscr = (union dscrptr *) ext;
1754 1.1.2.2 yamt dscr_size = sizeof(struct alloc_ext_entry) -1;
1755 1.1.2.2 yamt max_l_ad = lb_size - dscr_size;
1756 1.1.2.3 yamt l_ad_p = &ext->l_ad;
1757 1.1.2.3 yamt l_ad = udf_rw32(*l_ad_p);
1758 1.1.2.3 yamt data_pos = (uint8_t *) ext + dscr_size;
1759 1.1.2.2 yamt }
1760 1.1.2.3 yamt DPRINTF(PARANOIDADWLK, ("append, ext %d, offset %d, l_ad %d\n",
1761 1.1.2.3 yamt extnr, offset, udf_rw32(*l_ad_p)));
1762 1.1.2.3 yamt KASSERT(l_ad == udf_rw32(*l_ad_p));
1763 1.1.2.3 yamt
1764 1.1.2.2 yamt /* offset is offset within the current (E)FE/AED */
1765 1.1.2.2 yamt l_ad = udf_rw32(*l_ad_p);
1766 1.1.2.4 yamt crclen = udf_rw16(dscr->tag.desc_crc_len);
1767 1.1.2.2 yamt logblks_rec = udf_rw64(*logblks_rec_p);
1768 1.1.2.2 yamt
1769 1.1.2.2 yamt /* overwriting old piece? */
1770 1.1.2.2 yamt if (offset < l_ad) {
1771 1.1.2.2 yamt /* overwrite entry; compensate for the old element */
1772 1.1.2.2 yamt if (addr_type == UDF_ICB_SHORT_ALLOC) {
1773 1.1.2.2 yamt short_ad = (struct short_ad *) (data_pos + offset);
1774 1.1.2.2 yamt o_icb.len = short_ad->len;
1775 1.1.2.2 yamt o_icb.loc.part_num = udf_rw16(0); /* ignore */
1776 1.1.2.2 yamt o_icb.loc.lb_num = short_ad->lb_num;
1777 1.1.2.2 yamt } else if (addr_type == UDF_ICB_LONG_ALLOC) {
1778 1.1.2.2 yamt long_ad = (struct long_ad *) (data_pos + offset);
1779 1.1.2.2 yamt o_icb = *long_ad;
1780 1.1.2.2 yamt } else {
1781 1.1.2.2 yamt panic("Invalid address type in udf_append_adslot\n");
1782 1.1.2.2 yamt }
1783 1.1.2.2 yamt
1784 1.1.2.2 yamt len = udf_rw32(o_icb.len);
1785 1.1.2.2 yamt if (UDF_EXT_FLAGS(len) == UDF_EXT_ALLOCATED) {
1786 1.1.2.2 yamt /* adjust counts */
1787 1.1.2.2 yamt len = UDF_EXT_LEN(len);
1788 1.1.2.2 yamt logblks_rec -= (len + lb_size -1) / lb_size;
1789 1.1.2.2 yamt }
1790 1.1.2.2 yamt }
1791 1.1.2.2 yamt
1792 1.1.2.3 yamt /* check if we're not appending a redirection */
1793 1.1.2.3 yamt flags = UDF_EXT_FLAGS(udf_rw32(icb->len));
1794 1.1.2.3 yamt KASSERT(flags != UDF_EXT_REDIRECT);
1795 1.1.2.3 yamt
1796 1.1.2.3 yamt /* round down available space */
1797 1.1.2.3 yamt rest = adlen * ((max_l_ad - offset) / adlen);
1798 1.1.2.2 yamt if (rest <= adlen) {
1799 1.1.2.3 yamt /* have to append aed, see if we already have a spare one */
1800 1.1.2.3 yamt extnr++;
1801 1.1.2.3 yamt ext = udf_node->ext[extnr];
1802 1.1.2.3 yamt l_icb = udf_node->ext_loc[extnr];
1803 1.1.2.3 yamt if (ext == NULL) {
1804 1.1.2.3 yamt DPRINTF(ALLOC,("adding allocation extent %d\n", extnr));
1805 1.1.2.3 yamt
1806 1.1.2.5 yamt error = udf_reserve_space(ump, NULL, UDF_C_NODE,
1807 1.1.2.5 yamt vpart_num, 1, /* can fail */ false);
1808 1.1.2.5 yamt if (error) {
1809 1.1.2.5 yamt printf("UDF: couldn't reserve space for AED!\n");
1810 1.1.2.5 yamt return error;
1811 1.1.2.5 yamt }
1812 1.1.2.5 yamt error = udf_allocate_space(ump, NULL, UDF_C_NODE,
1813 1.1.2.5 yamt vpart_num, 1, &lmapping);
1814 1.1.2.3 yamt lb_num = lmapping;
1815 1.1.2.3 yamt if (error)
1816 1.1.2.5 yamt panic("UDF: couldn't allocate AED!\n");
1817 1.1.2.3 yamt
1818 1.1.2.3 yamt /* initialise pointer to location */
1819 1.1.2.3 yamt memset(&l_icb, 0, sizeof(struct long_ad));
1820 1.1.2.3 yamt l_icb.len = udf_rw32(lb_size | UDF_EXT_REDIRECT);
1821 1.1.2.3 yamt l_icb.loc.lb_num = udf_rw32(lb_num);
1822 1.1.2.3 yamt l_icb.loc.part_num = udf_rw16(vpart_num);
1823 1.1.2.3 yamt
1824 1.1.2.3 yamt /* create new aed descriptor */
1825 1.1.2.3 yamt udf_create_logvol_dscr(ump, udf_node, &l_icb, &extdscr);
1826 1.1.2.3 yamt ext = &extdscr->aee;
1827 1.1.2.3 yamt
1828 1.1.2.3 yamt udf_inittag(ump, &ext->tag, TAGID_ALLOCEXTENT, lb_num);
1829 1.1.2.3 yamt dscr_size = sizeof(struct alloc_ext_entry) -1;
1830 1.1.2.3 yamt max_l_ad = lb_size - dscr_size;
1831 1.1.2.3 yamt memset(ext->data, 0, max_l_ad);
1832 1.1.2.3 yamt ext->l_ad = udf_rw32(0);
1833 1.1.2.3 yamt ext->tag.desc_crc_len =
1834 1.1.2.4 yamt udf_rw16(dscr_size - UDF_DESC_TAG_LENGTH);
1835 1.1.2.3 yamt
1836 1.1.2.3 yamt /* declare aed */
1837 1.1.2.3 yamt udf_node->num_extensions++;
1838 1.1.2.3 yamt udf_node->ext_loc[extnr] = l_icb;
1839 1.1.2.3 yamt udf_node->ext[extnr] = ext;
1840 1.1.2.3 yamt }
1841 1.1.2.3 yamt /* add redirect and adjust l_ad and crclen for old descr */
1842 1.1.2.3 yamt if (addr_type == UDF_ICB_SHORT_ALLOC) {
1843 1.1.2.3 yamt short_ad = (struct short_ad *) (data_pos + offset);
1844 1.1.2.3 yamt short_ad->len = l_icb.len;
1845 1.1.2.3 yamt short_ad->lb_num = l_icb.loc.lb_num;
1846 1.1.2.3 yamt } else if (addr_type == UDF_ICB_LONG_ALLOC) {
1847 1.1.2.3 yamt long_ad = (struct long_ad *) (data_pos + offset);
1848 1.1.2.3 yamt *long_ad = l_icb;
1849 1.1.2.3 yamt }
1850 1.1.2.3 yamt l_ad += adlen;
1851 1.1.2.3 yamt crclen += adlen;
1852 1.1.2.4 yamt dscr->tag.desc_crc_len = udf_rw16(crclen);
1853 1.1.2.3 yamt *l_ad_p = udf_rw32(l_ad);
1854 1.1.2.3 yamt
1855 1.1.2.3 yamt /* advance to the new extension */
1856 1.1.2.3 yamt KASSERT(ext != NULL);
1857 1.1.2.3 yamt dscr = (union dscrptr *) ext;
1858 1.1.2.3 yamt dscr_size = sizeof(struct alloc_ext_entry) -1;
1859 1.1.2.3 yamt max_l_ad = lb_size - dscr_size;
1860 1.1.2.3 yamt data_pos = (uint8_t *) dscr + dscr_size;
1861 1.1.2.3 yamt
1862 1.1.2.3 yamt l_ad_p = &ext->l_ad;
1863 1.1.2.3 yamt l_ad = udf_rw32(*l_ad_p);
1864 1.1.2.4 yamt crclen = udf_rw16(dscr->tag.desc_crc_len);
1865 1.1.2.3 yamt offset = 0;
1866 1.1.2.3 yamt
1867 1.1.2.3 yamt /* adjust callees slot count for link insert */
1868 1.1.2.3 yamt *slot += 1;
1869 1.1.2.2 yamt }
1870 1.1.2.2 yamt
1871 1.1.2.2 yamt /* write out the element */
1872 1.1.2.3 yamt DPRINTF(PARANOIDADWLK, ("adding element : %p : v %d, lb %d, "
1873 1.1.2.3 yamt "len %d, flags %d\n", data_pos + offset,
1874 1.1.2.3 yamt icb->loc.part_num, icb->loc.lb_num,
1875 1.1.2.3 yamt UDF_EXT_LEN(icb->len), UDF_EXT_FLAGS(icb->len)));
1876 1.1.2.2 yamt if (addr_type == UDF_ICB_SHORT_ALLOC) {
1877 1.1.2.2 yamt short_ad = (struct short_ad *) (data_pos + offset);
1878 1.1.2.2 yamt short_ad->len = icb->len;
1879 1.1.2.2 yamt short_ad->lb_num = icb->loc.lb_num;
1880 1.1.2.2 yamt } else if (addr_type == UDF_ICB_LONG_ALLOC) {
1881 1.1.2.2 yamt long_ad = (struct long_ad *) (data_pos + offset);
1882 1.1.2.2 yamt *long_ad = *icb;
1883 1.1.2.2 yamt }
1884 1.1.2.2 yamt
1885 1.1.2.2 yamt /* adjust logblks recorded count */
1886 1.1.2.4 yamt len = udf_rw32(icb->len);
1887 1.1.2.4 yamt flags = UDF_EXT_FLAGS(len);
1888 1.1.2.3 yamt if (flags == UDF_EXT_ALLOCATED)
1889 1.1.2.4 yamt logblks_rec += (UDF_EXT_LEN(len) + lb_size -1) / lb_size;
1890 1.1.2.2 yamt *logblks_rec_p = udf_rw64(logblks_rec);
1891 1.1.2.2 yamt
1892 1.1.2.2 yamt /* adjust l_ad and crclen when needed */
1893 1.1.2.2 yamt if (offset >= l_ad) {
1894 1.1.2.2 yamt l_ad += adlen;
1895 1.1.2.2 yamt crclen += adlen;
1896 1.1.2.4 yamt dscr->tag.desc_crc_len = udf_rw16(crclen);
1897 1.1.2.2 yamt *l_ad_p = udf_rw32(l_ad);
1898 1.1.2.2 yamt }
1899 1.1.2.2 yamt
1900 1.1.2.2 yamt return 0;
1901 1.1.2.2 yamt }
1902 1.1.2.2 yamt
1903 1.1.2.2 yamt /* --------------------------------------------------------------------- */
1904 1.1.2.2 yamt
1905 1.1.2.3 yamt static void
1906 1.1.2.3 yamt udf_count_alloc_exts(struct udf_node *udf_node)
1907 1.1.2.3 yamt {
1908 1.1.2.3 yamt struct long_ad s_ad;
1909 1.1.2.3 yamt uint32_t lb_num, len, flags;
1910 1.1.2.3 yamt uint16_t vpart_num;
1911 1.1.2.3 yamt int slot, eof;
1912 1.1.2.3 yamt int num_extents, extnr;
1913 1.1.2.3 yamt int lb_size;
1914 1.1.2.3 yamt
1915 1.1.2.3 yamt if (udf_node->num_extensions == 0)
1916 1.1.2.3 yamt return;
1917 1.1.2.3 yamt
1918 1.1.2.3 yamt lb_size = udf_rw32(udf_node->ump->logical_vol->lb_size);
1919 1.1.2.3 yamt /* count number of allocation extents in use */
1920 1.1.2.3 yamt num_extents = 0;
1921 1.1.2.3 yamt slot = 0;
1922 1.1.2.3 yamt for (;;) {
1923 1.1.2.3 yamt udf_get_adslot(udf_node, slot, &s_ad, &eof);
1924 1.1.2.3 yamt if (eof)
1925 1.1.2.3 yamt break;
1926 1.1.2.3 yamt len = udf_rw32(s_ad.len);
1927 1.1.2.3 yamt flags = UDF_EXT_FLAGS(len);
1928 1.1.2.3 yamt
1929 1.1.2.3 yamt if (flags == UDF_EXT_REDIRECT)
1930 1.1.2.3 yamt num_extents++;
1931 1.1.2.3 yamt
1932 1.1.2.3 yamt slot++;
1933 1.1.2.3 yamt }
1934 1.1.2.3 yamt
1935 1.1.2.3 yamt DPRINTF(ALLOC, ("udf_count_alloc_ext counted %d live extents\n",
1936 1.1.2.3 yamt num_extents));
1937 1.1.2.3 yamt
1938 1.1.2.3 yamt /* XXX choice: we could delay freeing them on node writeout */
1939 1.1.2.3 yamt /* free excess entries */
1940 1.1.2.3 yamt extnr = num_extents;
1941 1.1.2.3 yamt for (;extnr < udf_node->num_extensions; extnr++) {
1942 1.1.2.3 yamt DPRINTF(ALLOC, ("freeing alloc ext %d\n", extnr));
1943 1.1.2.3 yamt /* free dscriptor */
1944 1.1.2.3 yamt s_ad = udf_node->ext_loc[extnr];
1945 1.1.2.3 yamt udf_free_logvol_dscr(udf_node->ump, &s_ad,
1946 1.1.2.3 yamt udf_node->ext[extnr]);
1947 1.1.2.3 yamt udf_node->ext[extnr] = NULL;
1948 1.1.2.3 yamt
1949 1.1.2.3 yamt /* free disc space */
1950 1.1.2.3 yamt lb_num = udf_rw32(s_ad.loc.lb_num);
1951 1.1.2.3 yamt vpart_num = udf_rw16(s_ad.loc.part_num);
1952 1.1.2.3 yamt udf_free_allocated_space(udf_node->ump, lb_num, vpart_num, 1);
1953 1.1.2.3 yamt
1954 1.1.2.3 yamt memset(&udf_node->ext_loc[extnr], 0, sizeof(struct long_ad));
1955 1.1.2.3 yamt }
1956 1.1.2.3 yamt
1957 1.1.2.3 yamt /* set our new number of allocation extents */
1958 1.1.2.3 yamt udf_node->num_extensions = num_extents;
1959 1.1.2.3 yamt }
1960 1.1.2.3 yamt
1961 1.1.2.3 yamt
1962 1.1.2.3 yamt /* --------------------------------------------------------------------- */
1963 1.1.2.3 yamt
1964 1.1.2.2 yamt /*
1965 1.1.2.2 yamt * Adjust the node's allocation descriptors to reflect the new mapping; do
1966 1.1.2.2 yamt * take note that we might glue to existing allocation descriptors.
1967 1.1.2.2 yamt *
1968 1.1.2.2 yamt * XXX Note there can only be one allocation being recorded/mount; maybe
1969 1.1.2.2 yamt * explicit allocation in shedule thread?
1970 1.1.2.2 yamt */
1971 1.1.2.2 yamt
1972 1.1.2.2 yamt static void
1973 1.1.2.2 yamt udf_record_allocation_in_node(struct udf_mount *ump, struct buf *buf,
1974 1.1.2.2 yamt uint16_t vpart_num, uint64_t *mapping, struct long_ad *node_ad_cpy)
1975 1.1.2.2 yamt {
1976 1.1.2.2 yamt struct vnode *vp = buf->b_vp;
1977 1.1.2.2 yamt struct udf_node *udf_node = VTOI(vp);
1978 1.1.2.2 yamt struct file_entry *fe;
1979 1.1.2.2 yamt struct extfile_entry *efe;
1980 1.1.2.2 yamt struct icb_tag *icbtag;
1981 1.1.2.2 yamt struct long_ad s_ad, c_ad;
1982 1.1.2.2 yamt uint64_t inflen, from, till;
1983 1.1.2.2 yamt uint64_t foffset, end_foffset, restart_foffset;
1984 1.1.2.2 yamt uint64_t orig_inflen, orig_lbrec, new_inflen, new_lbrec;
1985 1.1.2.2 yamt uint32_t num_lb, len, flags, lb_num;
1986 1.1.2.2 yamt uint32_t run_start;
1987 1.1.2.3 yamt uint32_t slot_offset, replace_len, replace;
1988 1.1.2.2 yamt int addr_type, icbflags;
1989 1.1.2.3 yamt // int udf_c_type = buf->b_udf_c_type;
1990 1.1.2.2 yamt int lb_size, run_length, eof;
1991 1.1.2.2 yamt int slot, cpy_slot, cpy_slots, restart_slot;
1992 1.1.2.2 yamt int error;
1993 1.1.2.2 yamt
1994 1.1.2.2 yamt DPRINTF(ALLOC, ("udf_record_allocation_in_node\n"));
1995 1.1.2.2 yamt
1996 1.1.2.3 yamt #if 0
1997 1.1.2.3 yamt /* XXX disable sanity check for now */
1998 1.1.2.2 yamt /* sanity check ... should be panic ? */
1999 1.1.2.2 yamt if ((udf_c_type != UDF_C_USERDATA) && (udf_c_type != UDF_C_FIDS))
2000 1.1.2.2 yamt return;
2001 1.1.2.3 yamt #endif
2002 1.1.2.2 yamt
2003 1.1.2.2 yamt lb_size = udf_rw32(udf_node->ump->logical_vol->lb_size);
2004 1.1.2.2 yamt
2005 1.1.2.2 yamt /* do the job */
2006 1.1.2.2 yamt UDF_LOCK_NODE(udf_node, 0); /* XXX can deadlock ? */
2007 1.1.2.3 yamt udf_node_sanity_check(udf_node, &orig_inflen, &orig_lbrec);
2008 1.1.2.2 yamt
2009 1.1.2.2 yamt fe = udf_node->fe;
2010 1.1.2.2 yamt efe = udf_node->efe;
2011 1.1.2.2 yamt if (fe) {
2012 1.1.2.2 yamt icbtag = &fe->icbtag;
2013 1.1.2.2 yamt inflen = udf_rw64(fe->inf_len);
2014 1.1.2.2 yamt } else {
2015 1.1.2.2 yamt icbtag = &efe->icbtag;
2016 1.1.2.2 yamt inflen = udf_rw64(efe->inf_len);
2017 1.1.2.2 yamt }
2018 1.1.2.2 yamt
2019 1.1.2.2 yamt /* do check if `till' is not past file information length */
2020 1.1.2.2 yamt from = buf->b_lblkno * lb_size;
2021 1.1.2.2 yamt till = MIN(inflen, from + buf->b_resid);
2022 1.1.2.2 yamt
2023 1.1.2.2 yamt num_lb = (till - from + lb_size -1) / lb_size;
2024 1.1.2.2 yamt
2025 1.1.2.3 yamt DPRINTF(ALLOC, ("record allocation from %"PRIu64" + %d\n", from, buf->b_bcount));
2026 1.1.2.2 yamt
2027 1.1.2.2 yamt icbflags = udf_rw16(icbtag->flags);
2028 1.1.2.2 yamt addr_type = icbflags & UDF_ICB_TAG_FLAGS_ALLOC_MASK;
2029 1.1.2.2 yamt
2030 1.1.2.2 yamt if (addr_type == UDF_ICB_INTERN_ALLOC) {
2031 1.1.2.2 yamt /* nothing to do */
2032 1.1.2.2 yamt /* XXX clean up rest of node? just in case? */
2033 1.1.2.2 yamt UDF_UNLOCK_NODE(udf_node, 0);
2034 1.1.2.2 yamt return;
2035 1.1.2.2 yamt }
2036 1.1.2.2 yamt
2037 1.1.2.2 yamt slot = 0;
2038 1.1.2.2 yamt cpy_slot = 0;
2039 1.1.2.2 yamt foffset = 0;
2040 1.1.2.2 yamt
2041 1.1.2.2 yamt /* 1) copy till first overlap piece to the rewrite buffer */
2042 1.1.2.2 yamt for (;;) {
2043 1.1.2.2 yamt udf_get_adslot(udf_node, slot, &s_ad, &eof);
2044 1.1.2.2 yamt if (eof) {
2045 1.1.2.2 yamt DPRINTF(WRITE,
2046 1.1.2.2 yamt ("Record allocation in node "
2047 1.1.2.2 yamt "failed: encountered EOF\n"));
2048 1.1.2.2 yamt UDF_UNLOCK_NODE(udf_node, 0);
2049 1.1.2.2 yamt buf->b_error = EINVAL;
2050 1.1.2.2 yamt return;
2051 1.1.2.2 yamt }
2052 1.1.2.2 yamt len = udf_rw32(s_ad.len);
2053 1.1.2.2 yamt flags = UDF_EXT_FLAGS(len);
2054 1.1.2.2 yamt len = UDF_EXT_LEN(len);
2055 1.1.2.2 yamt
2056 1.1.2.2 yamt if (flags == UDF_EXT_REDIRECT) {
2057 1.1.2.2 yamt slot++;
2058 1.1.2.2 yamt continue;
2059 1.1.2.2 yamt }
2060 1.1.2.2 yamt
2061 1.1.2.2 yamt end_foffset = foffset + len;
2062 1.1.2.2 yamt if (end_foffset > from)
2063 1.1.2.2 yamt break; /* found */
2064 1.1.2.2 yamt
2065 1.1.2.2 yamt node_ad_cpy[cpy_slot++] = s_ad;
2066 1.1.2.2 yamt
2067 1.1.2.2 yamt DPRINTF(ALLOC, ("\t1: vp %d, lb %d, len %d, flags %d "
2068 1.1.2.2 yamt "-> stack\n",
2069 1.1.2.2 yamt udf_rw16(s_ad.loc.part_num),
2070 1.1.2.2 yamt udf_rw32(s_ad.loc.lb_num),
2071 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(s_ad.len)),
2072 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(s_ad.len)) >> 30));
2073 1.1.2.2 yamt
2074 1.1.2.2 yamt foffset = end_foffset;
2075 1.1.2.2 yamt slot++;
2076 1.1.2.2 yamt }
2077 1.1.2.2 yamt restart_slot = slot;
2078 1.1.2.2 yamt restart_foffset = foffset;
2079 1.1.2.2 yamt
2080 1.1.2.2 yamt /* 2) trunc overlapping slot at overlap and copy it */
2081 1.1.2.2 yamt slot_offset = from - foffset;
2082 1.1.2.2 yamt if (slot_offset > 0) {
2083 1.1.2.2 yamt DPRINTF(ALLOC, ("\tslot_offset = %d, flags = %d (%d)\n",
2084 1.1.2.2 yamt slot_offset, flags >> 30, flags));
2085 1.1.2.2 yamt
2086 1.1.2.2 yamt s_ad.len = udf_rw32(slot_offset | flags);
2087 1.1.2.2 yamt node_ad_cpy[cpy_slot++] = s_ad;
2088 1.1.2.2 yamt
2089 1.1.2.2 yamt DPRINTF(ALLOC, ("\t2: vp %d, lb %d, len %d, flags %d "
2090 1.1.2.2 yamt "-> stack\n",
2091 1.1.2.2 yamt udf_rw16(s_ad.loc.part_num),
2092 1.1.2.2 yamt udf_rw32(s_ad.loc.lb_num),
2093 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(s_ad.len)),
2094 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(s_ad.len)) >> 30));
2095 1.1.2.2 yamt }
2096 1.1.2.2 yamt foffset += slot_offset;
2097 1.1.2.2 yamt
2098 1.1.2.2 yamt /* 3) insert new mappings */
2099 1.1.2.2 yamt memset(&s_ad, 0, sizeof(struct long_ad));
2100 1.1.2.2 yamt lb_num = 0;
2101 1.1.2.2 yamt for (lb_num = 0; lb_num < num_lb; lb_num++) {
2102 1.1.2.2 yamt run_start = mapping[lb_num];
2103 1.1.2.2 yamt run_length = 1;
2104 1.1.2.2 yamt while (lb_num < num_lb-1) {
2105 1.1.2.2 yamt if (mapping[lb_num+1] != mapping[lb_num]+1)
2106 1.1.2.2 yamt if (mapping[lb_num+1] != mapping[lb_num])
2107 1.1.2.2 yamt break;
2108 1.1.2.2 yamt run_length++;
2109 1.1.2.2 yamt lb_num++;
2110 1.1.2.2 yamt }
2111 1.1.2.2 yamt /* insert slot for this mapping */
2112 1.1.2.2 yamt len = run_length * lb_size;
2113 1.1.2.2 yamt
2114 1.1.2.2 yamt /* bounds checking */
2115 1.1.2.2 yamt if (foffset + len > till)
2116 1.1.2.2 yamt len = till - foffset;
2117 1.1.2.2 yamt KASSERT(foffset + len <= inflen);
2118 1.1.2.2 yamt
2119 1.1.2.2 yamt s_ad.len = udf_rw32(len | UDF_EXT_ALLOCATED);
2120 1.1.2.2 yamt s_ad.loc.part_num = udf_rw16(vpart_num);
2121 1.1.2.2 yamt s_ad.loc.lb_num = udf_rw32(run_start);
2122 1.1.2.2 yamt
2123 1.1.2.2 yamt foffset += len;
2124 1.1.2.2 yamt
2125 1.1.2.2 yamt /* paranoia */
2126 1.1.2.2 yamt if (len == 0) {
2127 1.1.2.2 yamt DPRINTF(WRITE,
2128 1.1.2.2 yamt ("Record allocation in node "
2129 1.1.2.2 yamt "failed: insert failed\n"));
2130 1.1.2.2 yamt UDF_UNLOCK_NODE(udf_node, 0);
2131 1.1.2.2 yamt buf->b_error = EINVAL;
2132 1.1.2.2 yamt return;
2133 1.1.2.2 yamt }
2134 1.1.2.2 yamt node_ad_cpy[cpy_slot++] = s_ad;
2135 1.1.2.2 yamt
2136 1.1.2.2 yamt DPRINTF(ALLOC, ("\t3: insert new mapping vp %d lb %d, len %d, "
2137 1.1.2.2 yamt "flags %d -> stack\n",
2138 1.1.2.2 yamt udf_rw16(s_ad.loc.part_num), udf_rw32(s_ad.loc.lb_num),
2139 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(s_ad.len)),
2140 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(s_ad.len)) >> 30));
2141 1.1.2.2 yamt }
2142 1.1.2.2 yamt
2143 1.1.2.2 yamt /* 4) pop replaced length */
2144 1.1.2.3 yamt slot = restart_slot;
2145 1.1.2.2 yamt foffset = restart_foffset;
2146 1.1.2.2 yamt
2147 1.1.2.3 yamt replace_len = till - foffset; /* total amount of bytes to pop */
2148 1.1.2.3 yamt slot_offset = from - foffset; /* offset in first encounted slot */
2149 1.1.2.3 yamt KASSERT((slot_offset % lb_size) == 0);
2150 1.1.2.3 yamt
2151 1.1.2.2 yamt for (;;) {
2152 1.1.2.2 yamt udf_get_adslot(udf_node, slot, &s_ad, &eof);
2153 1.1.2.2 yamt if (eof)
2154 1.1.2.2 yamt break;
2155 1.1.2.2 yamt
2156 1.1.2.2 yamt len = udf_rw32(s_ad.len);
2157 1.1.2.2 yamt flags = UDF_EXT_FLAGS(len);
2158 1.1.2.2 yamt len = UDF_EXT_LEN(len);
2159 1.1.2.2 yamt lb_num = udf_rw32(s_ad.loc.lb_num);
2160 1.1.2.2 yamt
2161 1.1.2.2 yamt if (flags == UDF_EXT_REDIRECT) {
2162 1.1.2.2 yamt slot++;
2163 1.1.2.2 yamt continue;
2164 1.1.2.2 yamt }
2165 1.1.2.2 yamt
2166 1.1.2.3 yamt DPRINTF(ALLOC, ("\t4i: got slot %d, slot_offset %d, "
2167 1.1.2.3 yamt "replace_len %d, "
2168 1.1.2.3 yamt "vp %d, lb %d, len %d, flags %d\n",
2169 1.1.2.3 yamt slot, slot_offset, replace_len,
2170 1.1.2.3 yamt udf_rw16(s_ad.loc.part_num),
2171 1.1.2.2 yamt udf_rw32(s_ad.loc.lb_num),
2172 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(s_ad.len)),
2173 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(s_ad.len)) >> 30));
2174 1.1.2.2 yamt
2175 1.1.2.3 yamt /* adjust for slot offset */
2176 1.1.2.3 yamt if (slot_offset) {
2177 1.1.2.3 yamt DPRINTF(ALLOC, ("\t4s: skipping %d\n", slot_offset));
2178 1.1.2.3 yamt lb_num += slot_offset / lb_size;
2179 1.1.2.3 yamt len -= slot_offset;
2180 1.1.2.3 yamt foffset += slot_offset;
2181 1.1.2.3 yamt replace_len -= slot_offset;
2182 1.1.2.3 yamt
2183 1.1.2.3 yamt /* mark adjusted */
2184 1.1.2.3 yamt slot_offset = 0;
2185 1.1.2.3 yamt }
2186 1.1.2.3 yamt
2187 1.1.2.3 yamt /* advance for (the rest of) this slot */
2188 1.1.2.3 yamt replace = MIN(len, replace_len);
2189 1.1.2.3 yamt DPRINTF(ALLOC, ("\t4d: replacing %d\n", replace));
2190 1.1.2.3 yamt
2191 1.1.2.3 yamt /* advance for this slot */
2192 1.1.2.3 yamt if (replace) {
2193 1.1.2.3 yamt /* note: dont round DOWN on num_lb since we then
2194 1.1.2.3 yamt * forget the last partial one */
2195 1.1.2.3 yamt num_lb = (replace + lb_size - 1) / lb_size;
2196 1.1.2.3 yamt if (flags != UDF_EXT_FREE) {
2197 1.1.2.3 yamt udf_free_allocated_space(ump, lb_num,
2198 1.1.2.3 yamt udf_rw16(s_ad.loc.part_num), num_lb);
2199 1.1.2.2 yamt }
2200 1.1.2.3 yamt lb_num += num_lb;
2201 1.1.2.3 yamt len -= replace;
2202 1.1.2.3 yamt foffset += replace;
2203 1.1.2.3 yamt replace_len -= replace;
2204 1.1.2.3 yamt }
2205 1.1.2.2 yamt
2206 1.1.2.3 yamt /* do we have a slot tail ? */
2207 1.1.2.2 yamt if (len) {
2208 1.1.2.3 yamt KASSERT(foffset % lb_size == 0);
2209 1.1.2.2 yamt
2210 1.1.2.2 yamt /* we arrived at our point, push remainder */
2211 1.1.2.2 yamt s_ad.len = udf_rw32(len | flags);
2212 1.1.2.2 yamt s_ad.loc.lb_num = udf_rw32(lb_num);
2213 1.1.2.3 yamt if (flags == UDF_EXT_FREE)
2214 1.1.2.3 yamt s_ad.loc.lb_num = udf_rw32(0);
2215 1.1.2.2 yamt node_ad_cpy[cpy_slot++] = s_ad;
2216 1.1.2.2 yamt foffset += len;
2217 1.1.2.2 yamt slot++;
2218 1.1.2.2 yamt
2219 1.1.2.2 yamt DPRINTF(ALLOC, ("\t4: vp %d, lb %d, len %d, flags %d "
2220 1.1.2.2 yamt "-> stack\n",
2221 1.1.2.2 yamt udf_rw16(s_ad.loc.part_num),
2222 1.1.2.2 yamt udf_rw32(s_ad.loc.lb_num),
2223 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(s_ad.len)),
2224 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(s_ad.len)) >> 30));
2225 1.1.2.2 yamt break;
2226 1.1.2.2 yamt }
2227 1.1.2.3 yamt
2228 1.1.2.2 yamt slot++;
2229 1.1.2.2 yamt }
2230 1.1.2.2 yamt
2231 1.1.2.2 yamt /* 5) copy remainder */
2232 1.1.2.2 yamt for (;;) {
2233 1.1.2.2 yamt udf_get_adslot(udf_node, slot, &s_ad, &eof);
2234 1.1.2.2 yamt if (eof)
2235 1.1.2.2 yamt break;
2236 1.1.2.2 yamt
2237 1.1.2.2 yamt len = udf_rw32(s_ad.len);
2238 1.1.2.2 yamt flags = UDF_EXT_FLAGS(len);
2239 1.1.2.2 yamt len = UDF_EXT_LEN(len);
2240 1.1.2.2 yamt
2241 1.1.2.2 yamt if (flags == UDF_EXT_REDIRECT) {
2242 1.1.2.2 yamt slot++;
2243 1.1.2.2 yamt continue;
2244 1.1.2.2 yamt }
2245 1.1.2.2 yamt
2246 1.1.2.2 yamt node_ad_cpy[cpy_slot++] = s_ad;
2247 1.1.2.2 yamt
2248 1.1.2.2 yamt DPRINTF(ALLOC, ("\t5: insert new mapping "
2249 1.1.2.2 yamt "vp %d lb %d, len %d, flags %d "
2250 1.1.2.2 yamt "-> stack\n",
2251 1.1.2.2 yamt udf_rw16(s_ad.loc.part_num),
2252 1.1.2.2 yamt udf_rw32(s_ad.loc.lb_num),
2253 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(s_ad.len)),
2254 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(s_ad.len)) >> 30));
2255 1.1.2.2 yamt
2256 1.1.2.2 yamt slot++;
2257 1.1.2.2 yamt }
2258 1.1.2.2 yamt
2259 1.1.2.2 yamt /* 6) reset node descriptors */
2260 1.1.2.2 yamt udf_wipe_adslots(udf_node);
2261 1.1.2.2 yamt
2262 1.1.2.2 yamt /* 7) copy back extents; merge when possible. Recounting on the fly */
2263 1.1.2.2 yamt cpy_slots = cpy_slot;
2264 1.1.2.2 yamt
2265 1.1.2.2 yamt c_ad = node_ad_cpy[0];
2266 1.1.2.2 yamt slot = 0;
2267 1.1.2.2 yamt DPRINTF(ALLOC, ("\t7s: stack -> got mapping vp %d "
2268 1.1.2.2 yamt "lb %d, len %d, flags %d\n",
2269 1.1.2.2 yamt udf_rw16(c_ad.loc.part_num),
2270 1.1.2.2 yamt udf_rw32(c_ad.loc.lb_num),
2271 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(c_ad.len)),
2272 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(c_ad.len)) >> 30));
2273 1.1.2.2 yamt
2274 1.1.2.2 yamt for (cpy_slot = 1; cpy_slot < cpy_slots; cpy_slot++) {
2275 1.1.2.2 yamt s_ad = node_ad_cpy[cpy_slot];
2276 1.1.2.2 yamt
2277 1.1.2.2 yamt DPRINTF(ALLOC, ("\t7i: stack -> got mapping vp %d "
2278 1.1.2.2 yamt "lb %d, len %d, flags %d\n",
2279 1.1.2.2 yamt udf_rw16(s_ad.loc.part_num),
2280 1.1.2.2 yamt udf_rw32(s_ad.loc.lb_num),
2281 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(s_ad.len)),
2282 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(s_ad.len)) >> 30));
2283 1.1.2.2 yamt
2284 1.1.2.2 yamt /* see if we can merge */
2285 1.1.2.2 yamt if (udf_ads_merge(lb_size, &c_ad, &s_ad)) {
2286 1.1.2.2 yamt /* not mergable (anymore) */
2287 1.1.2.2 yamt DPRINTF(ALLOC, ("\t7: appending vp %d lb %d, "
2288 1.1.2.2 yamt "len %d, flags %d\n",
2289 1.1.2.2 yamt udf_rw16(c_ad.loc.part_num),
2290 1.1.2.2 yamt udf_rw32(c_ad.loc.lb_num),
2291 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(c_ad.len)),
2292 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(c_ad.len)) >> 30));
2293 1.1.2.2 yamt
2294 1.1.2.3 yamt error = udf_append_adslot(udf_node, &slot, &c_ad);
2295 1.1.2.2 yamt if (error) {
2296 1.1.2.2 yamt buf->b_error = error;
2297 1.1.2.2 yamt goto out;
2298 1.1.2.2 yamt }
2299 1.1.2.2 yamt c_ad = s_ad;
2300 1.1.2.2 yamt slot++;
2301 1.1.2.2 yamt }
2302 1.1.2.2 yamt }
2303 1.1.2.2 yamt
2304 1.1.2.2 yamt /* 8) push rest slot (if any) */
2305 1.1.2.2 yamt if (UDF_EXT_LEN(c_ad.len) > 0) {
2306 1.1.2.2 yamt DPRINTF(ALLOC, ("\t8: last append vp %d lb %d, "
2307 1.1.2.2 yamt "len %d, flags %d\n",
2308 1.1.2.2 yamt udf_rw16(c_ad.loc.part_num),
2309 1.1.2.2 yamt udf_rw32(c_ad.loc.lb_num),
2310 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(c_ad.len)),
2311 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(c_ad.len)) >> 30));
2312 1.1.2.2 yamt
2313 1.1.2.3 yamt error = udf_append_adslot(udf_node, &slot, &c_ad);
2314 1.1.2.2 yamt if (error) {
2315 1.1.2.2 yamt buf->b_error = error;
2316 1.1.2.2 yamt goto out;
2317 1.1.2.2 yamt }
2318 1.1.2.2 yamt }
2319 1.1.2.2 yamt
2320 1.1.2.2 yamt out:
2321 1.1.2.3 yamt udf_count_alloc_exts(udf_node);
2322 1.1.2.2 yamt
2323 1.1.2.3 yamt /* the node's descriptors should now be sane */
2324 1.1.2.2 yamt udf_node_sanity_check(udf_node, &new_inflen, &new_lbrec);
2325 1.1.2.3 yamt UDF_UNLOCK_NODE(udf_node, 0);
2326 1.1.2.2 yamt
2327 1.1.2.2 yamt KASSERT(orig_inflen == new_inflen);
2328 1.1.2.2 yamt KASSERT(new_lbrec >= orig_lbrec);
2329 1.1.2.2 yamt
2330 1.1.2.2 yamt return;
2331 1.1.2.2 yamt }
2332 1.1.2.2 yamt
2333 1.1.2.2 yamt /* --------------------------------------------------------------------- */
2334 1.1.2.2 yamt
2335 1.1.2.2 yamt int
2336 1.1.2.2 yamt udf_grow_node(struct udf_node *udf_node, uint64_t new_size)
2337 1.1.2.2 yamt {
2338 1.1.2.2 yamt union dscrptr *dscr;
2339 1.1.2.2 yamt struct vnode *vp = udf_node->vnode;
2340 1.1.2.2 yamt struct udf_mount *ump = udf_node->ump;
2341 1.1.2.2 yamt struct file_entry *fe;
2342 1.1.2.2 yamt struct extfile_entry *efe;
2343 1.1.2.2 yamt struct icb_tag *icbtag;
2344 1.1.2.2 yamt struct long_ad c_ad, s_ad;
2345 1.1.2.2 yamt uint64_t size_diff, old_size, inflen, objsize, chunk, append_len;
2346 1.1.2.2 yamt uint64_t foffset, end_foffset;
2347 1.1.2.2 yamt uint64_t orig_inflen, orig_lbrec, new_inflen, new_lbrec;
2348 1.1.2.2 yamt uint32_t lb_size, dscr_size, crclen, lastblock_grow;
2349 1.1.2.3 yamt uint32_t icbflags, len, flags, max_len;
2350 1.1.2.2 yamt uint32_t max_l_ad, l_ad, l_ea;
2351 1.1.2.3 yamt uint16_t my_part, dst_part;
2352 1.1.2.2 yamt uint8_t *data_pos, *evacuated_data;
2353 1.1.2.3 yamt int addr_type;
2354 1.1.2.2 yamt int slot, cpy_slot;
2355 1.1.2.5 yamt int eof, error;
2356 1.1.2.2 yamt
2357 1.1.2.2 yamt DPRINTF(ALLOC, ("udf_grow_node\n"));
2358 1.1.2.2 yamt
2359 1.1.2.2 yamt UDF_LOCK_NODE(udf_node, 0);
2360 1.1.2.3 yamt udf_node_sanity_check(udf_node, &orig_inflen, &orig_lbrec);
2361 1.1.2.3 yamt
2362 1.1.2.2 yamt lb_size = udf_rw32(ump->logical_vol->lb_size);
2363 1.1.2.2 yamt max_len = ((UDF_EXT_MAXLEN / lb_size) * lb_size);
2364 1.1.2.2 yamt
2365 1.1.2.2 yamt fe = udf_node->fe;
2366 1.1.2.2 yamt efe = udf_node->efe;
2367 1.1.2.2 yamt if (fe) {
2368 1.1.2.2 yamt dscr = (union dscrptr *) fe;
2369 1.1.2.2 yamt icbtag = &fe->icbtag;
2370 1.1.2.2 yamt inflen = udf_rw64(fe->inf_len);
2371 1.1.2.2 yamt objsize = inflen;
2372 1.1.2.2 yamt dscr_size = sizeof(struct file_entry) -1;
2373 1.1.2.2 yamt l_ea = udf_rw32(fe->l_ea);
2374 1.1.2.2 yamt l_ad = udf_rw32(fe->l_ad);
2375 1.1.2.2 yamt } else {
2376 1.1.2.2 yamt dscr = (union dscrptr *) efe;
2377 1.1.2.2 yamt icbtag = &efe->icbtag;
2378 1.1.2.2 yamt inflen = udf_rw64(efe->inf_len);
2379 1.1.2.2 yamt objsize = udf_rw64(efe->obj_size);
2380 1.1.2.2 yamt dscr_size = sizeof(struct extfile_entry) -1;
2381 1.1.2.2 yamt l_ea = udf_rw32(efe->l_ea);
2382 1.1.2.2 yamt l_ad = udf_rw32(efe->l_ad);
2383 1.1.2.2 yamt }
2384 1.1.2.2 yamt data_pos = (uint8_t *) dscr + dscr_size + l_ea;
2385 1.1.2.2 yamt max_l_ad = lb_size - dscr_size - l_ea;
2386 1.1.2.2 yamt
2387 1.1.2.2 yamt icbflags = udf_rw16(icbtag->flags);
2388 1.1.2.2 yamt addr_type = icbflags & UDF_ICB_TAG_FLAGS_ALLOC_MASK;
2389 1.1.2.2 yamt
2390 1.1.2.2 yamt old_size = inflen;
2391 1.1.2.2 yamt size_diff = new_size - old_size;
2392 1.1.2.2 yamt
2393 1.1.2.2 yamt DPRINTF(ALLOC, ("\tfrom %"PRIu64" to %"PRIu64"\n", old_size, new_size));
2394 1.1.2.2 yamt
2395 1.1.2.2 yamt evacuated_data = NULL;
2396 1.1.2.2 yamt if (addr_type == UDF_ICB_INTERN_ALLOC) {
2397 1.1.2.2 yamt if (l_ad + size_diff <= max_l_ad) {
2398 1.1.2.2 yamt /* only reflect size change directly in the node */
2399 1.1.2.2 yamt inflen += size_diff;
2400 1.1.2.2 yamt objsize += size_diff;
2401 1.1.2.2 yamt l_ad += size_diff;
2402 1.1.2.2 yamt crclen = dscr_size - UDF_DESC_TAG_LENGTH + l_ea + l_ad;
2403 1.1.2.2 yamt if (fe) {
2404 1.1.2.2 yamt fe->inf_len = udf_rw64(inflen);
2405 1.1.2.2 yamt fe->l_ad = udf_rw32(l_ad);
2406 1.1.2.4 yamt fe->tag.desc_crc_len = udf_rw16(crclen);
2407 1.1.2.2 yamt } else {
2408 1.1.2.2 yamt efe->inf_len = udf_rw64(inflen);
2409 1.1.2.2 yamt efe->obj_size = udf_rw64(objsize);
2410 1.1.2.2 yamt efe->l_ad = udf_rw32(l_ad);
2411 1.1.2.4 yamt efe->tag.desc_crc_len = udf_rw16(crclen);
2412 1.1.2.2 yamt }
2413 1.1.2.2 yamt error = 0;
2414 1.1.2.2 yamt
2415 1.1.2.2 yamt /* set new size for uvm */
2416 1.1.2.2 yamt uvm_vnp_setsize(vp, old_size);
2417 1.1.2.2 yamt uvm_vnp_setwritesize(vp, new_size);
2418 1.1.2.2 yamt
2419 1.1.2.2 yamt #if 0
2420 1.1.2.2 yamt /* zero append space in buffer */
2421 1.1.2.2 yamt uvm_vnp_zerorange(vp, old_size, new_size - old_size);
2422 1.1.2.2 yamt #endif
2423 1.1.2.2 yamt
2424 1.1.2.3 yamt udf_node_sanity_check(udf_node, &new_inflen, &new_lbrec);
2425 1.1.2.3 yamt
2426 1.1.2.2 yamt /* unlock */
2427 1.1.2.2 yamt UDF_UNLOCK_NODE(udf_node, 0);
2428 1.1.2.2 yamt
2429 1.1.2.2 yamt KASSERT(new_inflen == orig_inflen + size_diff);
2430 1.1.2.2 yamt KASSERT(new_lbrec == orig_lbrec);
2431 1.1.2.2 yamt KASSERT(new_lbrec == 0);
2432 1.1.2.2 yamt return 0;
2433 1.1.2.2 yamt }
2434 1.1.2.2 yamt
2435 1.1.2.2 yamt DPRINTF(ALLOC, ("\tCONVERT from internal\n"));
2436 1.1.2.2 yamt
2437 1.1.2.2 yamt if (old_size > 0) {
2438 1.1.2.2 yamt /* allocate some space and copy in the stuff to keep */
2439 1.1.2.2 yamt evacuated_data = malloc(lb_size, M_UDFTEMP, M_WAITOK);
2440 1.1.2.2 yamt memset(evacuated_data, 0, lb_size);
2441 1.1.2.2 yamt
2442 1.1.2.2 yamt /* node is locked, so safe to exit mutex */
2443 1.1.2.2 yamt UDF_UNLOCK_NODE(udf_node, 0);
2444 1.1.2.2 yamt
2445 1.1.2.2 yamt /* read in using the `normal' vn_rdwr() */
2446 1.1.2.2 yamt error = vn_rdwr(UIO_READ, udf_node->vnode,
2447 1.1.2.2 yamt evacuated_data, old_size, 0,
2448 1.1.2.2 yamt UIO_SYSSPACE, IO_ALTSEMANTICS | IO_NODELOCKED,
2449 1.1.2.2 yamt FSCRED, NULL, NULL);
2450 1.1.2.2 yamt
2451 1.1.2.2 yamt /* enter again */
2452 1.1.2.2 yamt UDF_LOCK_NODE(udf_node, 0);
2453 1.1.2.2 yamt }
2454 1.1.2.2 yamt
2455 1.1.2.3 yamt /* convert to a normal alloc and select type */
2456 1.1.2.3 yamt my_part = udf_rw16(udf_node->loc.loc.part_num);
2457 1.1.2.5 yamt dst_part = udf_get_record_vpart(ump, udf_get_c_type(udf_node));
2458 1.1.2.3 yamt addr_type = UDF_ICB_SHORT_ALLOC;
2459 1.1.2.3 yamt if (dst_part != my_part)
2460 1.1.2.3 yamt addr_type = UDF_ICB_LONG_ALLOC;
2461 1.1.2.3 yamt
2462 1.1.2.2 yamt icbflags &= ~UDF_ICB_TAG_FLAGS_ALLOC_MASK;
2463 1.1.2.3 yamt icbflags |= addr_type;
2464 1.1.2.2 yamt icbtag->flags = udf_rw16(icbflags);
2465 1.1.2.2 yamt
2466 1.1.2.2 yamt /* wipe old descriptor space */
2467 1.1.2.2 yamt udf_wipe_adslots(udf_node);
2468 1.1.2.2 yamt
2469 1.1.2.2 yamt memset(&c_ad, 0, sizeof(struct long_ad));
2470 1.1.2.2 yamt c_ad.len = udf_rw32(old_size | UDF_EXT_FREE);
2471 1.1.2.2 yamt c_ad.loc.part_num = udf_rw16(0); /* not relevant */
2472 1.1.2.2 yamt c_ad.loc.lb_num = udf_rw32(0); /* not relevant */
2473 1.1.2.2 yamt
2474 1.1.2.2 yamt slot = 0;
2475 1.1.2.2 yamt } else {
2476 1.1.2.2 yamt /* goto the last entry (if any) */
2477 1.1.2.2 yamt slot = 0;
2478 1.1.2.2 yamt cpy_slot = 0;
2479 1.1.2.2 yamt foffset = 0;
2480 1.1.2.2 yamt memset(&c_ad, 0, sizeof(struct long_ad));
2481 1.1.2.2 yamt for (;;) {
2482 1.1.2.2 yamt udf_get_adslot(udf_node, slot, &c_ad, &eof);
2483 1.1.2.2 yamt if (eof)
2484 1.1.2.2 yamt break;
2485 1.1.2.2 yamt
2486 1.1.2.2 yamt len = udf_rw32(c_ad.len);
2487 1.1.2.2 yamt flags = UDF_EXT_FLAGS(len);
2488 1.1.2.2 yamt len = UDF_EXT_LEN(len);
2489 1.1.2.2 yamt
2490 1.1.2.2 yamt end_foffset = foffset + len;
2491 1.1.2.2 yamt if (flags != UDF_EXT_REDIRECT)
2492 1.1.2.2 yamt foffset = end_foffset;
2493 1.1.2.2 yamt
2494 1.1.2.2 yamt slot++;
2495 1.1.2.2 yamt }
2496 1.1.2.2 yamt /* at end of adslots */
2497 1.1.2.2 yamt
2498 1.1.2.2 yamt /* special case if the old size was zero, then there is no last slot */
2499 1.1.2.2 yamt if (old_size == 0) {
2500 1.1.2.2 yamt c_ad.len = udf_rw32(0 | UDF_EXT_FREE);
2501 1.1.2.2 yamt c_ad.loc.part_num = udf_rw16(0); /* not relevant */
2502 1.1.2.2 yamt c_ad.loc.lb_num = udf_rw32(0); /* not relevant */
2503 1.1.2.2 yamt } else {
2504 1.1.2.2 yamt /* refetch last slot */
2505 1.1.2.2 yamt slot--;
2506 1.1.2.2 yamt udf_get_adslot(udf_node, slot, &c_ad, &eof);
2507 1.1.2.2 yamt }
2508 1.1.2.2 yamt }
2509 1.1.2.2 yamt
2510 1.1.2.2 yamt /*
2511 1.1.2.2 yamt * If the length of the last slot is not a multiple of lb_size, adjust
2512 1.1.2.2 yamt * length so that it is; don't forget to adjust `append_len'! relevant for
2513 1.1.2.2 yamt * extending existing files
2514 1.1.2.2 yamt */
2515 1.1.2.2 yamt len = udf_rw32(c_ad.len);
2516 1.1.2.2 yamt flags = UDF_EXT_FLAGS(len);
2517 1.1.2.2 yamt len = UDF_EXT_LEN(len);
2518 1.1.2.2 yamt
2519 1.1.2.2 yamt lastblock_grow = 0;
2520 1.1.2.2 yamt if (len % lb_size > 0) {
2521 1.1.2.2 yamt lastblock_grow = lb_size - (len % lb_size);
2522 1.1.2.2 yamt lastblock_grow = MIN(size_diff, lastblock_grow);
2523 1.1.2.2 yamt len += lastblock_grow;
2524 1.1.2.2 yamt c_ad.len = udf_rw32(len | flags);
2525 1.1.2.2 yamt
2526 1.1.2.2 yamt /* TODO zero appened space in buffer! */
2527 1.1.2.2 yamt /* using uvm_vnp_zerorange(vp, old_size, new_size - old_size); ? */
2528 1.1.2.2 yamt }
2529 1.1.2.2 yamt memset(&s_ad, 0, sizeof(struct long_ad));
2530 1.1.2.2 yamt
2531 1.1.2.2 yamt /* size_diff can be bigger than allowed, so grow in chunks */
2532 1.1.2.2 yamt append_len = size_diff - lastblock_grow;
2533 1.1.2.2 yamt while (append_len > 0) {
2534 1.1.2.2 yamt chunk = MIN(append_len, max_len);
2535 1.1.2.2 yamt s_ad.len = udf_rw32(chunk | UDF_EXT_FREE);
2536 1.1.2.2 yamt s_ad.loc.part_num = udf_rw16(0);
2537 1.1.2.2 yamt s_ad.loc.lb_num = udf_rw32(0);
2538 1.1.2.2 yamt
2539 1.1.2.2 yamt if (udf_ads_merge(lb_size, &c_ad, &s_ad)) {
2540 1.1.2.2 yamt /* not mergable (anymore) */
2541 1.1.2.3 yamt error = udf_append_adslot(udf_node, &slot, &c_ad);
2542 1.1.2.2 yamt if (error)
2543 1.1.2.2 yamt goto errorout;
2544 1.1.2.2 yamt slot++;
2545 1.1.2.2 yamt c_ad = s_ad;
2546 1.1.2.2 yamt memset(&s_ad, 0, sizeof(struct long_ad));
2547 1.1.2.2 yamt }
2548 1.1.2.2 yamt append_len -= chunk;
2549 1.1.2.2 yamt }
2550 1.1.2.2 yamt
2551 1.1.2.2 yamt /* if there is a rest piece in the accumulator, append it */
2552 1.1.2.3 yamt if (UDF_EXT_LEN(udf_rw32(c_ad.len)) > 0) {
2553 1.1.2.3 yamt error = udf_append_adslot(udf_node, &slot, &c_ad);
2554 1.1.2.2 yamt if (error)
2555 1.1.2.2 yamt goto errorout;
2556 1.1.2.2 yamt slot++;
2557 1.1.2.2 yamt }
2558 1.1.2.2 yamt
2559 1.1.2.2 yamt /* if there is a rest piece that didn't fit, append it */
2560 1.1.2.3 yamt if (UDF_EXT_LEN(udf_rw32(s_ad.len)) > 0) {
2561 1.1.2.3 yamt error = udf_append_adslot(udf_node, &slot, &s_ad);
2562 1.1.2.2 yamt if (error)
2563 1.1.2.2 yamt goto errorout;
2564 1.1.2.2 yamt slot++;
2565 1.1.2.2 yamt }
2566 1.1.2.2 yamt
2567 1.1.2.2 yamt inflen += size_diff;
2568 1.1.2.2 yamt objsize += size_diff;
2569 1.1.2.2 yamt if (fe) {
2570 1.1.2.2 yamt fe->inf_len = udf_rw64(inflen);
2571 1.1.2.2 yamt } else {
2572 1.1.2.2 yamt efe->inf_len = udf_rw64(inflen);
2573 1.1.2.2 yamt efe->obj_size = udf_rw64(objsize);
2574 1.1.2.2 yamt }
2575 1.1.2.2 yamt error = 0;
2576 1.1.2.2 yamt
2577 1.1.2.2 yamt if (evacuated_data) {
2578 1.1.2.2 yamt /* set new write size for uvm */
2579 1.1.2.2 yamt uvm_vnp_setwritesize(vp, old_size);
2580 1.1.2.2 yamt
2581 1.1.2.2 yamt /* write out evacuated data */
2582 1.1.2.2 yamt error = vn_rdwr(UIO_WRITE, udf_node->vnode,
2583 1.1.2.2 yamt evacuated_data, old_size, 0,
2584 1.1.2.2 yamt UIO_SYSSPACE, IO_ALTSEMANTICS | IO_NODELOCKED,
2585 1.1.2.2 yamt FSCRED, NULL, NULL);
2586 1.1.2.2 yamt uvm_vnp_setsize(vp, old_size);
2587 1.1.2.2 yamt }
2588 1.1.2.2 yamt
2589 1.1.2.2 yamt errorout:
2590 1.1.2.2 yamt if (evacuated_data)
2591 1.1.2.2 yamt free(evacuated_data, M_UDFTEMP);
2592 1.1.2.3 yamt
2593 1.1.2.3 yamt udf_count_alloc_exts(udf_node);
2594 1.1.2.2 yamt
2595 1.1.2.2 yamt udf_node_sanity_check(udf_node, &new_inflen, &new_lbrec);
2596 1.1.2.3 yamt UDF_UNLOCK_NODE(udf_node, 0);
2597 1.1.2.3 yamt
2598 1.1.2.2 yamt KASSERT(new_inflen == orig_inflen + size_diff);
2599 1.1.2.2 yamt KASSERT(new_lbrec == orig_lbrec);
2600 1.1.2.2 yamt
2601 1.1.2.2 yamt return error;
2602 1.1.2.2 yamt }
2603 1.1.2.2 yamt
2604 1.1.2.2 yamt /* --------------------------------------------------------------------- */
2605 1.1.2.2 yamt
2606 1.1.2.2 yamt int
2607 1.1.2.2 yamt udf_shrink_node(struct udf_node *udf_node, uint64_t new_size)
2608 1.1.2.2 yamt {
2609 1.1.2.2 yamt struct vnode *vp = udf_node->vnode;
2610 1.1.2.2 yamt struct udf_mount *ump = udf_node->ump;
2611 1.1.2.2 yamt struct file_entry *fe;
2612 1.1.2.2 yamt struct extfile_entry *efe;
2613 1.1.2.2 yamt struct icb_tag *icbtag;
2614 1.1.2.2 yamt struct long_ad c_ad, s_ad, *node_ad_cpy;
2615 1.1.2.2 yamt uint64_t size_diff, old_size, inflen, objsize;
2616 1.1.2.2 yamt uint64_t foffset, end_foffset;
2617 1.1.2.2 yamt uint64_t orig_inflen, orig_lbrec, new_inflen, new_lbrec;
2618 1.1.2.2 yamt uint32_t lb_size, dscr_size, crclen;
2619 1.1.2.5 yamt uint32_t slot_offset, slot_offset_lb;
2620 1.1.2.2 yamt uint32_t len, flags, max_len;
2621 1.1.2.2 yamt uint32_t num_lb, lb_num;
2622 1.1.2.2 yamt uint32_t max_l_ad, l_ad, l_ea;
2623 1.1.2.2 yamt uint16_t vpart_num;
2624 1.1.2.2 yamt uint8_t *data_pos;
2625 1.1.2.2 yamt int icbflags, addr_type;
2626 1.1.2.2 yamt int slot, cpy_slot, cpy_slots;
2627 1.1.2.2 yamt int eof, error;
2628 1.1.2.2 yamt
2629 1.1.2.2 yamt DPRINTF(ALLOC, ("udf_shrink_node\n"));
2630 1.1.2.2 yamt
2631 1.1.2.2 yamt UDF_LOCK_NODE(udf_node, 0);
2632 1.1.2.3 yamt udf_node_sanity_check(udf_node, &orig_inflen, &orig_lbrec);
2633 1.1.2.3 yamt
2634 1.1.2.2 yamt lb_size = udf_rw32(ump->logical_vol->lb_size);
2635 1.1.2.2 yamt max_len = ((UDF_EXT_MAXLEN / lb_size) * lb_size);
2636 1.1.2.2 yamt
2637 1.1.2.2 yamt /* do the work */
2638 1.1.2.2 yamt fe = udf_node->fe;
2639 1.1.2.2 yamt efe = udf_node->efe;
2640 1.1.2.2 yamt if (fe) {
2641 1.1.2.2 yamt icbtag = &fe->icbtag;
2642 1.1.2.2 yamt inflen = udf_rw64(fe->inf_len);
2643 1.1.2.2 yamt objsize = inflen;
2644 1.1.2.2 yamt dscr_size = sizeof(struct file_entry) -1;
2645 1.1.2.2 yamt l_ea = udf_rw32(fe->l_ea);
2646 1.1.2.2 yamt l_ad = udf_rw32(fe->l_ad);
2647 1.1.2.2 yamt data_pos = (uint8_t *) fe + dscr_size + l_ea;
2648 1.1.2.2 yamt } else {
2649 1.1.2.2 yamt icbtag = &efe->icbtag;
2650 1.1.2.2 yamt inflen = udf_rw64(efe->inf_len);
2651 1.1.2.2 yamt objsize = udf_rw64(efe->obj_size);
2652 1.1.2.2 yamt dscr_size = sizeof(struct extfile_entry) -1;
2653 1.1.2.2 yamt l_ea = udf_rw32(efe->l_ea);
2654 1.1.2.2 yamt l_ad = udf_rw32(efe->l_ad);
2655 1.1.2.2 yamt data_pos = (uint8_t *) efe + dscr_size + l_ea;
2656 1.1.2.2 yamt }
2657 1.1.2.2 yamt max_l_ad = lb_size - dscr_size - l_ea;
2658 1.1.2.2 yamt
2659 1.1.2.2 yamt icbflags = udf_rw16(icbtag->flags);
2660 1.1.2.2 yamt addr_type = icbflags & UDF_ICB_TAG_FLAGS_ALLOC_MASK;
2661 1.1.2.2 yamt
2662 1.1.2.2 yamt old_size = inflen;
2663 1.1.2.2 yamt size_diff = old_size - new_size;
2664 1.1.2.2 yamt
2665 1.1.2.2 yamt DPRINTF(ALLOC, ("\tfrom %"PRIu64" to %"PRIu64"\n", old_size, new_size));
2666 1.1.2.2 yamt
2667 1.1.2.2 yamt /* shrink the node to its new size */
2668 1.1.2.2 yamt if (addr_type == UDF_ICB_INTERN_ALLOC) {
2669 1.1.2.2 yamt /* only reflect size change directly in the node */
2670 1.1.2.2 yamt KASSERT(new_size <= max_l_ad);
2671 1.1.2.2 yamt inflen -= size_diff;
2672 1.1.2.2 yamt objsize -= size_diff;
2673 1.1.2.2 yamt l_ad -= size_diff;
2674 1.1.2.2 yamt crclen = dscr_size - UDF_DESC_TAG_LENGTH + l_ea + l_ad;
2675 1.1.2.2 yamt if (fe) {
2676 1.1.2.2 yamt fe->inf_len = udf_rw64(inflen);
2677 1.1.2.2 yamt fe->l_ad = udf_rw32(l_ad);
2678 1.1.2.4 yamt fe->tag.desc_crc_len = udf_rw16(crclen);
2679 1.1.2.2 yamt } else {
2680 1.1.2.2 yamt efe->inf_len = udf_rw64(inflen);
2681 1.1.2.2 yamt efe->obj_size = udf_rw64(objsize);
2682 1.1.2.2 yamt efe->l_ad = udf_rw32(l_ad);
2683 1.1.2.4 yamt efe->tag.desc_crc_len = udf_rw16(crclen);
2684 1.1.2.2 yamt }
2685 1.1.2.2 yamt error = 0;
2686 1.1.2.3 yamt
2687 1.1.2.3 yamt /* clear the space in the descriptor */
2688 1.1.2.3 yamt KASSERT(old_size > new_size);
2689 1.1.2.3 yamt memset(data_pos + new_size, 0, old_size - new_size);
2690 1.1.2.3 yamt
2691 1.1.2.2 yamt /* TODO zero appened space in buffer! */
2692 1.1.2.2 yamt /* using uvm_vnp_zerorange(vp, old_size, old_size - new_size); ? */
2693 1.1.2.2 yamt
2694 1.1.2.2 yamt /* set new size for uvm */
2695 1.1.2.2 yamt uvm_vnp_setsize(vp, new_size);
2696 1.1.2.2 yamt
2697 1.1.2.2 yamt udf_node_sanity_check(udf_node, &new_inflen, &new_lbrec);
2698 1.1.2.3 yamt UDF_UNLOCK_NODE(udf_node, 0);
2699 1.1.2.3 yamt
2700 1.1.2.2 yamt KASSERT(new_inflen == orig_inflen - size_diff);
2701 1.1.2.2 yamt KASSERT(new_lbrec == orig_lbrec);
2702 1.1.2.2 yamt KASSERT(new_lbrec == 0);
2703 1.1.2.2 yamt
2704 1.1.2.2 yamt return 0;
2705 1.1.2.2 yamt }
2706 1.1.2.2 yamt
2707 1.1.2.2 yamt /* setup node cleanup extents copy space */
2708 1.1.2.2 yamt node_ad_cpy = malloc(lb_size * UDF_MAX_ALLOC_EXTENTS,
2709 1.1.2.2 yamt M_UDFMNT, M_WAITOK);
2710 1.1.2.2 yamt memset(node_ad_cpy, 0, lb_size * UDF_MAX_ALLOC_EXTENTS);
2711 1.1.2.2 yamt
2712 1.1.2.2 yamt /*
2713 1.1.2.2 yamt * Shrink the node by releasing the allocations and truncate the last
2714 1.1.2.2 yamt * allocation to the new size. If the new size fits into the
2715 1.1.2.2 yamt * allocation descriptor itself, transform it into an
2716 1.1.2.2 yamt * UDF_ICB_INTERN_ALLOC.
2717 1.1.2.2 yamt */
2718 1.1.2.2 yamt slot = 0;
2719 1.1.2.2 yamt cpy_slot = 0;
2720 1.1.2.2 yamt foffset = 0;
2721 1.1.2.2 yamt
2722 1.1.2.2 yamt /* 1) copy till first overlap piece to the rewrite buffer */
2723 1.1.2.2 yamt for (;;) {
2724 1.1.2.2 yamt udf_get_adslot(udf_node, slot, &s_ad, &eof);
2725 1.1.2.2 yamt if (eof) {
2726 1.1.2.2 yamt DPRINTF(WRITE,
2727 1.1.2.2 yamt ("Shrink node failed: "
2728 1.1.2.2 yamt "encountered EOF\n"));
2729 1.1.2.2 yamt error = EINVAL;
2730 1.1.2.2 yamt goto errorout; /* panic? */
2731 1.1.2.2 yamt }
2732 1.1.2.2 yamt len = udf_rw32(s_ad.len);
2733 1.1.2.2 yamt flags = UDF_EXT_FLAGS(len);
2734 1.1.2.2 yamt len = UDF_EXT_LEN(len);
2735 1.1.2.2 yamt
2736 1.1.2.2 yamt if (flags == UDF_EXT_REDIRECT) {
2737 1.1.2.2 yamt slot++;
2738 1.1.2.2 yamt continue;
2739 1.1.2.2 yamt }
2740 1.1.2.2 yamt
2741 1.1.2.2 yamt end_foffset = foffset + len;
2742 1.1.2.2 yamt if (end_foffset > new_size)
2743 1.1.2.2 yamt break; /* found */
2744 1.1.2.2 yamt
2745 1.1.2.2 yamt node_ad_cpy[cpy_slot++] = s_ad;
2746 1.1.2.2 yamt
2747 1.1.2.2 yamt DPRINTF(ALLOC, ("\t1: vp %d, lb %d, len %d, flags %d "
2748 1.1.2.2 yamt "-> stack\n",
2749 1.1.2.2 yamt udf_rw16(s_ad.loc.part_num),
2750 1.1.2.2 yamt udf_rw32(s_ad.loc.lb_num),
2751 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(s_ad.len)),
2752 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(s_ad.len)) >> 30));
2753 1.1.2.2 yamt
2754 1.1.2.2 yamt foffset = end_foffset;
2755 1.1.2.2 yamt slot++;
2756 1.1.2.2 yamt }
2757 1.1.2.2 yamt slot_offset = new_size - foffset;
2758 1.1.2.2 yamt
2759 1.1.2.2 yamt /* 2) trunc overlapping slot at overlap and copy it */
2760 1.1.2.2 yamt if (slot_offset > 0) {
2761 1.1.2.2 yamt lb_num = udf_rw32(s_ad.loc.lb_num);
2762 1.1.2.2 yamt vpart_num = udf_rw16(s_ad.loc.part_num);
2763 1.1.2.2 yamt
2764 1.1.2.2 yamt if (flags == UDF_EXT_ALLOCATED) {
2765 1.1.2.5 yamt /* calculate extent in lb, and offset in lb */
2766 1.1.2.5 yamt num_lb = (len + lb_size -1) / lb_size;
2767 1.1.2.5 yamt slot_offset_lb = (slot_offset + lb_size -1) / lb_size;
2768 1.1.2.5 yamt
2769 1.1.2.5 yamt /* adjust our slot */
2770 1.1.2.5 yamt lb_num += slot_offset_lb;
2771 1.1.2.5 yamt num_lb -= slot_offset_lb;
2772 1.1.2.2 yamt
2773 1.1.2.2 yamt udf_free_allocated_space(ump, lb_num, vpart_num, num_lb);
2774 1.1.2.2 yamt }
2775 1.1.2.2 yamt
2776 1.1.2.2 yamt s_ad.len = udf_rw32(slot_offset | flags);
2777 1.1.2.2 yamt node_ad_cpy[cpy_slot++] = s_ad;
2778 1.1.2.2 yamt slot++;
2779 1.1.2.2 yamt
2780 1.1.2.2 yamt DPRINTF(ALLOC, ("\t2: vp %d, lb %d, len %d, flags %d "
2781 1.1.2.2 yamt "-> stack\n",
2782 1.1.2.2 yamt udf_rw16(s_ad.loc.part_num),
2783 1.1.2.2 yamt udf_rw32(s_ad.loc.lb_num),
2784 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(s_ad.len)),
2785 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(s_ad.len)) >> 30));
2786 1.1.2.2 yamt }
2787 1.1.2.2 yamt
2788 1.1.2.2 yamt /* 3) delete remainder */
2789 1.1.2.2 yamt for (;;) {
2790 1.1.2.2 yamt udf_get_adslot(udf_node, slot, &s_ad, &eof);
2791 1.1.2.2 yamt if (eof)
2792 1.1.2.2 yamt break;
2793 1.1.2.2 yamt
2794 1.1.2.2 yamt len = udf_rw32(s_ad.len);
2795 1.1.2.2 yamt flags = UDF_EXT_FLAGS(len);
2796 1.1.2.2 yamt len = UDF_EXT_LEN(len);
2797 1.1.2.2 yamt
2798 1.1.2.2 yamt if (flags == UDF_EXT_REDIRECT) {
2799 1.1.2.2 yamt slot++;
2800 1.1.2.2 yamt continue;
2801 1.1.2.2 yamt }
2802 1.1.2.2 yamt
2803 1.1.2.2 yamt DPRINTF(ALLOC, ("\t3: delete remainder "
2804 1.1.2.2 yamt "vp %d lb %d, len %d, flags %d\n",
2805 1.1.2.2 yamt udf_rw16(s_ad.loc.part_num),
2806 1.1.2.2 yamt udf_rw32(s_ad.loc.lb_num),
2807 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(s_ad.len)),
2808 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(s_ad.len)) >> 30));
2809 1.1.2.2 yamt
2810 1.1.2.2 yamt if (flags == UDF_EXT_ALLOCATED) {
2811 1.1.2.2 yamt lb_num = udf_rw32(s_ad.loc.lb_num);
2812 1.1.2.2 yamt vpart_num = udf_rw16(s_ad.loc.part_num);
2813 1.1.2.2 yamt num_lb = (len + lb_size - 1) / lb_size;
2814 1.1.2.2 yamt
2815 1.1.2.2 yamt udf_free_allocated_space(ump, lb_num, vpart_num,
2816 1.1.2.2 yamt num_lb);
2817 1.1.2.2 yamt }
2818 1.1.2.2 yamt
2819 1.1.2.2 yamt slot++;
2820 1.1.2.2 yamt }
2821 1.1.2.2 yamt
2822 1.1.2.2 yamt /* 4) if it will fit into the descriptor then convert */
2823 1.1.2.2 yamt if (new_size < max_l_ad) {
2824 1.1.2.2 yamt /*
2825 1.1.2.2 yamt * resque/evacuate old piece by reading it in, and convert it
2826 1.1.2.2 yamt * to internal alloc.
2827 1.1.2.2 yamt */
2828 1.1.2.2 yamt if (new_size == 0) {
2829 1.1.2.2 yamt /* XXX/TODO only for zero sizing now */
2830 1.1.2.2 yamt udf_wipe_adslots(udf_node);
2831 1.1.2.2 yamt
2832 1.1.2.2 yamt icbflags &= ~UDF_ICB_TAG_FLAGS_ALLOC_MASK;
2833 1.1.2.2 yamt icbflags |= UDF_ICB_INTERN_ALLOC;
2834 1.1.2.2 yamt icbtag->flags = udf_rw16(icbflags);
2835 1.1.2.2 yamt
2836 1.1.2.2 yamt inflen -= size_diff; KASSERT(inflen == 0);
2837 1.1.2.2 yamt objsize -= size_diff;
2838 1.1.2.2 yamt l_ad = new_size;
2839 1.1.2.2 yamt crclen = dscr_size - UDF_DESC_TAG_LENGTH + l_ea + l_ad;
2840 1.1.2.2 yamt if (fe) {
2841 1.1.2.2 yamt fe->inf_len = udf_rw64(inflen);
2842 1.1.2.2 yamt fe->l_ad = udf_rw32(l_ad);
2843 1.1.2.4 yamt fe->tag.desc_crc_len = udf_rw16(crclen);
2844 1.1.2.2 yamt } else {
2845 1.1.2.2 yamt efe->inf_len = udf_rw64(inflen);
2846 1.1.2.2 yamt efe->obj_size = udf_rw64(objsize);
2847 1.1.2.2 yamt efe->l_ad = udf_rw32(l_ad);
2848 1.1.2.4 yamt efe->tag.desc_crc_len = udf_rw16(crclen);
2849 1.1.2.2 yamt }
2850 1.1.2.2 yamt /* eventually copy in evacuated piece */
2851 1.1.2.2 yamt /* set new size for uvm */
2852 1.1.2.2 yamt uvm_vnp_setsize(vp, new_size);
2853 1.1.2.2 yamt
2854 1.1.2.2 yamt free(node_ad_cpy, M_UDFMNT);
2855 1.1.2.3 yamt udf_node_sanity_check(udf_node, &new_inflen, &new_lbrec);
2856 1.1.2.3 yamt
2857 1.1.2.2 yamt UDF_UNLOCK_NODE(udf_node, 0);
2858 1.1.2.2 yamt
2859 1.1.2.2 yamt KASSERT(new_inflen == orig_inflen - size_diff);
2860 1.1.2.2 yamt KASSERT(new_inflen == 0);
2861 1.1.2.2 yamt KASSERT(new_lbrec == 0);
2862 1.1.2.2 yamt
2863 1.1.2.2 yamt return 0;
2864 1.1.2.2 yamt }
2865 1.1.2.2 yamt
2866 1.1.2.2 yamt printf("UDF_SHRINK_NODE: could convert to internal alloc!\n");
2867 1.1.2.2 yamt }
2868 1.1.2.2 yamt
2869 1.1.2.2 yamt /* 5) reset node descriptors */
2870 1.1.2.2 yamt udf_wipe_adslots(udf_node);
2871 1.1.2.2 yamt
2872 1.1.2.2 yamt /* 6) copy back extents; merge when possible. Recounting on the fly */
2873 1.1.2.2 yamt cpy_slots = cpy_slot;
2874 1.1.2.2 yamt
2875 1.1.2.2 yamt c_ad = node_ad_cpy[0];
2876 1.1.2.2 yamt slot = 0;
2877 1.1.2.2 yamt for (cpy_slot = 1; cpy_slot < cpy_slots; cpy_slot++) {
2878 1.1.2.2 yamt s_ad = node_ad_cpy[cpy_slot];
2879 1.1.2.2 yamt
2880 1.1.2.2 yamt DPRINTF(ALLOC, ("\t6: stack -> got mapping vp %d "
2881 1.1.2.2 yamt "lb %d, len %d, flags %d\n",
2882 1.1.2.2 yamt udf_rw16(s_ad.loc.part_num),
2883 1.1.2.2 yamt udf_rw32(s_ad.loc.lb_num),
2884 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(s_ad.len)),
2885 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(s_ad.len)) >> 30));
2886 1.1.2.2 yamt
2887 1.1.2.2 yamt /* see if we can merge */
2888 1.1.2.2 yamt if (udf_ads_merge(lb_size, &c_ad, &s_ad)) {
2889 1.1.2.2 yamt /* not mergable (anymore) */
2890 1.1.2.2 yamt DPRINTF(ALLOC, ("\t6: appending vp %d lb %d, "
2891 1.1.2.2 yamt "len %d, flags %d\n",
2892 1.1.2.2 yamt udf_rw16(c_ad.loc.part_num),
2893 1.1.2.2 yamt udf_rw32(c_ad.loc.lb_num),
2894 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(c_ad.len)),
2895 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(c_ad.len)) >> 30));
2896 1.1.2.2 yamt
2897 1.1.2.3 yamt error = udf_append_adslot(udf_node, &slot, &c_ad);
2898 1.1.2.2 yamt if (error)
2899 1.1.2.2 yamt goto errorout; /* panic? */
2900 1.1.2.2 yamt c_ad = s_ad;
2901 1.1.2.2 yamt slot++;
2902 1.1.2.2 yamt }
2903 1.1.2.2 yamt }
2904 1.1.2.2 yamt
2905 1.1.2.2 yamt /* 7) push rest slot (if any) */
2906 1.1.2.2 yamt if (UDF_EXT_LEN(c_ad.len) > 0) {
2907 1.1.2.2 yamt DPRINTF(ALLOC, ("\t7: last append vp %d lb %d, "
2908 1.1.2.2 yamt "len %d, flags %d\n",
2909 1.1.2.2 yamt udf_rw16(c_ad.loc.part_num),
2910 1.1.2.2 yamt udf_rw32(c_ad.loc.lb_num),
2911 1.1.2.2 yamt UDF_EXT_LEN(udf_rw32(c_ad.len)),
2912 1.1.2.2 yamt UDF_EXT_FLAGS(udf_rw32(c_ad.len)) >> 30));
2913 1.1.2.2 yamt
2914 1.1.2.3 yamt error = udf_append_adslot(udf_node, &slot, &c_ad);
2915 1.1.2.2 yamt if (error)
2916 1.1.2.2 yamt goto errorout; /* panic? */
2917 1.1.2.2 yamt ;
2918 1.1.2.2 yamt }
2919 1.1.2.2 yamt
2920 1.1.2.2 yamt inflen -= size_diff;
2921 1.1.2.2 yamt objsize -= size_diff;
2922 1.1.2.2 yamt if (fe) {
2923 1.1.2.2 yamt fe->inf_len = udf_rw64(inflen);
2924 1.1.2.2 yamt } else {
2925 1.1.2.2 yamt efe->inf_len = udf_rw64(inflen);
2926 1.1.2.2 yamt efe->obj_size = udf_rw64(objsize);
2927 1.1.2.2 yamt }
2928 1.1.2.2 yamt error = 0;
2929 1.1.2.2 yamt
2930 1.1.2.2 yamt /* set new size for uvm */
2931 1.1.2.2 yamt uvm_vnp_setsize(vp, new_size);
2932 1.1.2.2 yamt
2933 1.1.2.2 yamt errorout:
2934 1.1.2.2 yamt free(node_ad_cpy, M_UDFMNT);
2935 1.1.2.3 yamt
2936 1.1.2.3 yamt udf_count_alloc_exts(udf_node);
2937 1.1.2.2 yamt
2938 1.1.2.2 yamt udf_node_sanity_check(udf_node, &new_inflen, &new_lbrec);
2939 1.1.2.3 yamt UDF_UNLOCK_NODE(udf_node, 0);
2940 1.1.2.3 yamt
2941 1.1.2.2 yamt KASSERT(new_inflen == orig_inflen - size_diff);
2942 1.1.2.2 yamt
2943 1.1.2.2 yamt return error;
2944 1.1.2.2 yamt }
2945 1.1.2.2 yamt
2946