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