source: mainline/uspace/lib/ext4/libext4_extent.c@ d510ac01

lfn serial ticket/834-toolchain-update topic/msim-upgrade topic/simplify-dev-export
Last change on this file since d510ac01 was d510ac01, checked in by Frantisek Princ <frantisek.princ@…>, 13 years ago

Fixed bug with different sizes in writing file on extents

  • Property mode set to 100644
File size: 29.6 KB
Line 
1/*
2 * Copyright (c) 2012 Frantisek Princ
3 * All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
7 * are met:
8 *
9 * - Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer.
11 * - Redistributions in binary form must reproduce the above copyright
12 * notice, this list of conditions and the following disclaimer in the
13 * documentation and/or other materials provided with the distribution.
14 * - The name of the author may not be used to endorse or promote products
15 * derived from this software without specific prior written permission.
16 *
17 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
22 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
23 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
24 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
25 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
26 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27 */
28
29/** @addtogroup libext4
30 * @{
31 */
32
33/**
34 * @file libext4_extent.c
35 * @brief Ext4 extent structures operations.
36 */
37
38#include <byteorder.h>
39#include <errno.h>
40#include <malloc.h>
41#include "libext4.h"
42
43/** Get logical number of the block covered by extent.
44 *
45 * @param extent extent to load number from
46 * @return logical number of the first block covered by extent
47 */
48uint32_t ext4_extent_get_first_block(ext4_extent_t *extent)
49{
50 return uint32_t_le2host(extent->first_block);
51}
52
53/** Set logical number of the first block covered by extent.
54 *
55 * @param extent extent to set number to
56 * @param iblock logical number of the first block covered by extent
57 */
58void ext4_extent_set_first_block(ext4_extent_t *extent, uint32_t iblock)
59{
60 extent->first_block = host2uint32_t_le(iblock);
61}
62
63/** Get number of blocks covered by extent.
64 *
65 * @param extent extent to load count from
66 * @return number of blocks covered by extent
67 */
68uint16_t ext4_extent_get_block_count(ext4_extent_t *extent)
69{
70 return uint16_t_le2host(extent->block_count);
71}
72
73/** Set number of blocks covered by extent.
74 *
75 * @param extent extent to load count from
76 * @param count number of blocks covered by extent
77 */
78void ext4_extent_set_block_count(ext4_extent_t *extent, uint16_t count)
79{
80 extent->block_count = host2uint16_t_le(count);
81}
82
83/** Get physical number of the first block covered by extent.
84 *
85 * @param extent extent to load number
86 * @return physical number of the first block covered by extent
87 */
88uint64_t ext4_extent_get_start(ext4_extent_t *extent)
89{
90 return ((uint64_t)uint16_t_le2host(extent->start_hi)) << 32 |
91 ((uint64_t)uint32_t_le2host(extent->start_lo));
92}
93
94/** Set physical number of the first block covered by extent.
95 *
96 * @param extent extent to load number
97 * @param fblock physical number of the first block covered by extent
98 */
99void ext4_extent_set_start(ext4_extent_t *extent, uint64_t fblock)
100{
101 extent->start_lo = host2uint32_t_le((fblock << 32) >> 32);
102 extent->start_hi = host2uint16_t_le((uint16_t)(fblock >> 32));
103}
104
105/** Get logical number of the block covered by extent index.
106 *
107 * @param index extent index to load number from
108 * @return logical number of the first block covered by extent index
109 */
110uint32_t ext4_extent_index_get_first_block(ext4_extent_index_t *index)
111{
112 return uint32_t_le2host(index->first_block);
113}
114
115/** Set logical number of the block covered by extent index.
116 *
117 * @param index extent index to set number to
118 * @param iblock logical number of the first block covered by extent index
119 */
120void ext4_extent_index_set_first_block(ext4_extent_index_t *index,
121 uint32_t iblock)
122{
123 index->first_block = host2uint32_t_le(iblock);
124}
125
126/** Get physical number of block where the child node is located.
127 *
128 * @param index extent index to load number from
129 * @return physical number of the block with child node
130 */
131uint64_t ext4_extent_index_get_leaf(ext4_extent_index_t *index)
132{
133 return ((uint64_t)uint16_t_le2host(index->leaf_hi)) << 32 |
134 ((uint64_t)uint32_t_le2host(index->leaf_lo));
135}
136
137/** Set physical number of block where the child node is located.
138 *
139 * @param index extent index to set number to
140 * @param fblock physical number of the block with child node
141 */
142void ext4_extent_index_set_leaf(ext4_extent_index_t *index, uint64_t fblock)
143{
144 index->leaf_lo = host2uint32_t_le((fblock << 32) >> 32);
145 index->leaf_hi = host2uint16_t_le((uint16_t)(fblock >> 32));
146}
147
148/** Get magic value from extent header.
149 *
150 * @param header extent header to load value from
151 * @return magic value of extent header
152 */
153uint16_t ext4_extent_header_get_magic(ext4_extent_header_t *header)
154{
155 return uint16_t_le2host(header->magic);
156}
157
158/** Set magic value to extent header.
159 *
160 * @param header extent header to set value to
161 * @param magic magic value of extent header
162 */
163void ext4_extent_header_set_magic(ext4_extent_header_t *header, uint16_t magic)
164{
165 header->magic = host2uint16_t_le(magic);
166}
167
168/** Get number of entries from extent header
169 *
170 * @param header extent header to get value from
171 * @return number of entries covered by extent header
172 */
173uint16_t ext4_extent_header_get_entries_count(ext4_extent_header_t *header)
174{
175 return uint16_t_le2host(header->entries_count);
176}
177
178/** Set number of entries to extent header
179 *
180 * @param header extent header to set value to
181 * @param count number of entries covered by extent header
182 */
183void ext4_extent_header_set_entries_count(ext4_extent_header_t *header,
184 uint16_t count)
185{
186 header->entries_count = host2uint16_t_le(count);
187}
188
189/** Get maximum number of entries from extent header
190 *
191 * @param header extent header to get value from
192 * @return maximum number of entries covered by extent header
193 */
194uint16_t ext4_extent_header_get_max_entries_count(ext4_extent_header_t *header)
195{
196 return uint16_t_le2host(header->max_entries_count);
197}
198
199/** Set maximum number of entries to extent header
200 *
201 * @param header extent header to set value to
202 * @param max_count maximum number of entries covered by extent header
203 */
204void ext4_extent_header_set_max_entries_count(ext4_extent_header_t *header,
205 uint16_t max_count)
206{
207 header->max_entries_count = host2uint16_t_le(max_count);
208}
209
210/** Get depth of extent subtree.
211 *
212 * @param header extent header to get value from
213 * @return depth of extent subtree
214 */
215uint16_t ext4_extent_header_get_depth(ext4_extent_header_t *header)
216{
217 return uint16_t_le2host(header->depth);
218}
219
220/** Set depth of extent subtree.
221 *
222 * @param header extent header to set value to
223 * @param depth depth of extent subtree
224 */
225void ext4_extent_header_set_depth(ext4_extent_header_t *header, uint16_t depth)
226{
227 header->depth = host2uint16_t_le(depth);
228}
229
230/** Get generation from extent header
231 *
232 * @param header extent header to get value from
233 * @return generation
234 */
235uint32_t ext4_extent_header_get_generation(ext4_extent_header_t *header)
236{
237 return uint32_t_le2host(header->generation);
238}
239
240/** Set generation to extent header
241 *
242 * @param header extent header to set value to
243 * @param generation generation
244 */
245void ext4_extent_header_set_generation(ext4_extent_header_t *header,
246 uint32_t generation)
247{
248 header->generation = host2uint32_t_le(generation);
249}
250
251/** Binary search in extent index node.
252 *
253 * @param header extent header of index node
254 * @param index output value - found index will be set here
255 * @param iblock logical block number to find in index node
256 */
257static void ext4_extent_binsearch_idx(ext4_extent_header_t *header,
258 ext4_extent_index_t **index, uint32_t iblock)
259{
260 ext4_extent_index_t *r, *l, *m;
261
262 uint16_t entries_count = ext4_extent_header_get_entries_count(header);
263
264 /* Initialize bounds */
265 l = EXT4_EXTENT_FIRST_INDEX(header) + 1;
266 r = EXT4_EXTENT_FIRST_INDEX(header) + entries_count - 1;
267
268 /* Do binary search */
269 while (l <= r) {
270 m = l + (r - l) / 2;
271 uint32_t first_block = ext4_extent_index_get_first_block(m);
272 if (iblock < first_block) {
273 r = m - 1;
274 } else {
275 l = m + 1;
276 }
277 }
278
279 /* Set output value */
280 *index = l - 1;
281}
282
283/** Binary search in extent leaf node.
284 * @param header extent header of leaf node
285 * @param extent output value - found extent will be set here,
286 * or NULL if node is empty
287 * @param iblock logical block number to find in leaf node
288 *
289 */
290static void ext4_extent_binsearch(ext4_extent_header_t *header,
291 ext4_extent_t **extent, uint32_t iblock)
292{
293 ext4_extent_t *r, *l, *m;
294
295 uint16_t entries_count = ext4_extent_header_get_entries_count(header);
296
297 if (entries_count == 0) {
298 /* this leaf is empty */
299 *extent = NULL;
300 return;
301 }
302
303 /* Initialize bounds */
304 l = EXT4_EXTENT_FIRST(header) + 1;
305 r = EXT4_EXTENT_FIRST(header) + entries_count - 1;
306
307 /* Do binary search */
308 while (l <= r) {
309 m = l + (r - l) / 2;
310 uint32_t first_block = ext4_extent_get_first_block(m);
311 if (iblock < first_block) {
312 r = m - 1;
313 } else {
314 l = m + 1;
315 }
316 }
317
318 /* Set output value */
319 *extent = l - 1;
320}
321
322/** Find physical block in the extent tree by logical block number.
323 *
324 * There is no need to save path in the tree during this algorithm.
325 *
326 * @param inode_ref i-node to load block from
327 * @param iblock logical block number to find
328 * @param fblock output value for physical block number
329 * @return error code
330 */
331int ext4_extent_find_block(ext4_inode_ref_t *inode_ref,
332 uint32_t iblock, uint32_t *fblock)
333{
334 int rc;
335
336 /* Compute bound defined by i-node size */
337 uint64_t inode_size = ext4_inode_get_size(
338 inode_ref->fs->superblock, inode_ref->inode);
339
340 uint32_t block_size = ext4_superblock_get_block_size(
341 inode_ref->fs->superblock);
342
343 uint32_t last_idx = (inode_size - 1) / block_size;
344
345 /* Check if requested iblock is not over size of i-node */
346 if (iblock > last_idx) {
347 *fblock = 0;
348 return EOK;
349 }
350
351 block_t* block = NULL;
352
353 /* Walk through extent tree */
354 ext4_extent_header_t *header = ext4_inode_get_extent_header(inode_ref->inode);
355
356 while (ext4_extent_header_get_depth(header) != 0) {
357
358 /* Search index in node */
359 ext4_extent_index_t *index;
360 ext4_extent_binsearch_idx(header, &index, iblock);
361
362 /* Load child node and set values for the next iteration */
363 uint64_t child = ext4_extent_index_get_leaf(index);
364
365 if (block != NULL) {
366 block_put(block);
367 }
368
369 rc = block_get(&block, inode_ref->fs->device, child, BLOCK_FLAGS_NONE);
370 if (rc != EOK) {
371 return rc;
372 }
373
374 header = (ext4_extent_header_t *)block->data;
375 }
376
377 /* Search extent in the leaf block */
378 ext4_extent_t* extent = NULL;
379 ext4_extent_binsearch(header, &extent, iblock);
380
381 /* Prevent empty leaf */
382 if (extent == NULL) {
383 *fblock = 0;
384 } else {
385
386 /* Compute requested physical block address */
387 uint32_t phys_block;
388 uint32_t first = ext4_extent_get_first_block(extent);
389 phys_block = ext4_extent_get_start(extent) + iblock - first;
390
391 *fblock = phys_block;
392 }
393
394 /* Cleanup */
395 if (block != NULL) {
396 block_put(block);
397 }
398
399 return EOK;
400}
401
402
403/** Find extent for specified iblock.
404 *
405 * This function is used for finding block in the extent tree with
406 * saving the path through the tree for possible future modifications.
407 *
408 * @param inode_ref i-node to read extent tree from
409 * @param iblock iblock to find extent for
410 * @param ret_path output value for loaded path from extent tree
411 * @return error code
412 */
413static int ext4_extent_find_extent(ext4_inode_ref_t *inode_ref,
414 uint32_t iblock, ext4_extent_path_t **ret_path)
415{
416 int rc;
417
418 ext4_extent_header_t *eh =
419 ext4_inode_get_extent_header(inode_ref->inode);
420
421 uint16_t depth = ext4_extent_header_get_depth(eh);
422
423 ext4_extent_path_t *tmp_path;
424
425 /* Added 2 for possible tree growing */
426 tmp_path = malloc(sizeof(ext4_extent_path_t) * (depth + 2));
427 if (tmp_path == NULL) {
428 return ENOMEM;
429 }
430
431 /* Initialize structure for algorithm start */
432 tmp_path[0].block = inode_ref->block;
433 tmp_path[0].header = eh;
434
435 /* Walk through the extent tree */
436 uint16_t pos = 0;
437 while (ext4_extent_header_get_depth(eh) != 0) {
438
439 /* Search index in index node by iblock */
440 ext4_extent_binsearch_idx(tmp_path[pos].header, &tmp_path[pos].index, iblock);
441
442 tmp_path[pos].depth = depth;
443 tmp_path[pos].extent = NULL;
444
445 assert(tmp_path[pos].index != NULL);
446
447 /* Load information for the next iteration */
448 uint64_t fblock = ext4_extent_index_get_leaf(tmp_path[pos].index);
449
450 block_t *block;
451 rc = block_get(&block, inode_ref->fs->device, fblock, BLOCK_FLAGS_NONE);
452 if (rc != EOK) {
453 goto cleanup;
454 }
455
456 pos++;
457
458 eh = (ext4_extent_header_t *)block->data;
459 tmp_path[pos].block = block;
460 tmp_path[pos].header = eh;
461
462 }
463
464 tmp_path[pos].depth = 0;
465 tmp_path[pos].extent = NULL;
466 tmp_path[pos].index = NULL;
467
468 /* Find extent in the leaf node */
469 ext4_extent_binsearch(tmp_path[pos].header, &tmp_path[pos].extent, iblock);
470
471 *ret_path = tmp_path;
472
473 return EOK;
474
475cleanup:
476 /* Put loaded blocks
477 * From 1: 0 is a block with inode data
478 */
479 for (uint16_t i = 1; i < tmp_path->depth; ++i) {
480 if (tmp_path[i].block) {
481 block_put(tmp_path[i].block);
482 }
483 }
484
485 /* Destroy temporary data structure */
486 free(tmp_path);
487
488 return rc;
489}
490
491/** Release extent and all data blocks covered by the extent.
492 *
493 * @param inode_ref i-node to release extent and block from
494 * @param extent extent to release
495 * @return error code
496 */
497static int ext4_extent_release(
498 ext4_inode_ref_t *inode_ref, ext4_extent_t *extent)
499{
500 int rc;
501
502 /* Compute number of the first physical block to release */
503 uint64_t start = ext4_extent_get_start(extent);
504 uint16_t block_count = ext4_extent_get_block_count(extent);
505
506 rc = ext4_balloc_free_blocks(inode_ref, start, block_count);
507 if (rc != EOK) {
508 EXT4FS_DBG("Error in releasing data blocks");
509 return rc;
510 }
511
512 return EOK;
513}
514
515/** Recursively release the whole branch of the extent tree.
516 *
517 * For each entry of the node release the subbranch and finally release
518 * the node. In the leaf node all extents will be released.
519 *
520 * @param inode_ref i-node where the branch is released
521 * @param index index in the non-leaf node to be released
522 * with the whole subtree
523 * @return error code
524 */
525static int ext4_extent_release_branch(ext4_inode_ref_t *inode_ref,
526 ext4_extent_index_t *index)
527{
528 int rc;
529
530 block_t* block;
531
532 uint32_t fblock = ext4_extent_index_get_leaf(index);
533
534 rc = block_get(&block, inode_ref->fs->device, fblock, BLOCK_FLAGS_NONE);
535 if (rc != EOK) {
536 EXT4FS_DBG("ERROR get_block");
537 return rc;
538 }
539
540 ext4_extent_header_t *header = block->data;
541
542 if (ext4_extent_header_get_depth(header)) {
543
544 /* The node is non-leaf, do recursion */
545
546 ext4_extent_index_t *idx = EXT4_EXTENT_FIRST_INDEX(header);
547
548 /* Release all subbranches */
549 for (uint32_t i = 0; i < ext4_extent_header_get_entries_count(header); ++i, ++idx) {
550 rc = ext4_extent_release_branch(inode_ref, idx);
551 if (rc != EOK) {
552 EXT4FS_DBG("error recursion");
553 return rc;
554 }
555 }
556 } else {
557
558 /* Leaf node reached */
559 ext4_extent_t *ext = EXT4_EXTENT_FIRST(header);
560
561 /* Release all extents and stop recursion */
562
563 for (uint32_t i = 0; i < ext4_extent_header_get_entries_count(header); ++i, ++ext) {
564 rc = ext4_extent_release(inode_ref, ext);
565 if (rc != EOK) {
566 EXT4FS_DBG("error recursion");
567 return rc;
568 }
569 }
570 }
571
572 /* Release data block where the node was stored */
573
574 rc = block_put(block);
575 if (rc != EOK) {
576 EXT4FS_DBG("ERROR block_put returned \%d", rc);
577 return rc;
578 }
579
580 ext4_balloc_free_block(inode_ref, fblock);
581
582 return EOK;
583}
584
585/** Release all data blocks starting from specified logical block.
586 *
587 * @param inode_ref i-node to release blocks from
588 * @param iblock_from first logical block to release
589 */
590int ext4_extent_release_blocks_from(ext4_inode_ref_t *inode_ref,
591 uint32_t iblock_from)
592{
593 int rc = EOK;
594
595 /* Find the first extent to modify */
596 ext4_extent_path_t *path;
597 rc = ext4_extent_find_extent(inode_ref, iblock_from, &path);
598 if (rc != EOK) {
599 return rc;
600 }
601
602 /* Jump to last item of the path (extent) */
603 ext4_extent_path_t *path_ptr = path;
604 while (path_ptr->depth != 0) {
605 path_ptr++;
606 }
607
608 assert(path_ptr->extent != NULL);
609
610 /* First extent maybe released partially */
611 uint32_t first_iblock = ext4_extent_get_first_block(path_ptr->extent);
612 uint32_t first_fblock = ext4_extent_get_start(path_ptr->extent) + iblock_from - first_iblock;
613
614
615 uint16_t block_count = ext4_extent_get_block_count(path_ptr->extent);
616
617 uint16_t delete_count = block_count - (
618 ext4_extent_get_start(path_ptr->extent) - first_fblock);
619
620 /* Release all blocks */
621 rc = ext4_balloc_free_blocks(inode_ref, first_fblock, delete_count);
622 if (rc != EOK) {
623 goto cleanup;
624 }
625
626 /* Correct counter */
627 block_count -= delete_count;
628 ext4_extent_set_block_count(path_ptr->extent, block_count);
629
630 /* Initialize the following loop */
631 uint16_t entries = ext4_extent_header_get_entries_count(path_ptr->header);
632 ext4_extent_t *tmp_ext = path_ptr->extent + 1;
633 ext4_extent_t *stop_ext = EXT4_EXTENT_FIRST(path_ptr->header) + entries;
634
635 /* If first extent empty, release it */
636 if (block_count == 0) {
637 entries--;
638 }
639
640 /* Release all successors of the first extent in the same node */
641 while (tmp_ext < stop_ext) {
642 first_fblock = ext4_extent_get_start(tmp_ext);
643 delete_count = ext4_extent_get_block_count(tmp_ext);
644
645 rc = ext4_balloc_free_blocks(inode_ref, first_fblock, delete_count);
646 if (rc != EOK) {
647 goto cleanup;
648 }
649
650 entries--;
651 tmp_ext++;
652 }
653
654 ext4_extent_header_set_entries_count(path_ptr->header, entries);
655 path_ptr->block->dirty = true;
656
657 /* If leaf node is empty, parent entry must be modified */
658 bool remove_parent_record = false;
659
660 /* Don't release root block (including inode data) !!! */
661 if ((path_ptr != path) && (entries == 0)) {
662 rc = ext4_balloc_free_block(inode_ref, path_ptr->block->lba);
663 if (rc != EOK) {
664 goto cleanup;
665 }
666 remove_parent_record = true;
667 }
668
669 /* Jump to the parent */
670 --path_ptr;
671
672 /* Release all successors in all tree levels */
673 while (path_ptr >= path) {
674 entries = ext4_extent_header_get_entries_count(path_ptr->header);
675 ext4_extent_index_t *index = path_ptr->index + 1;
676 ext4_extent_index_t *stop =
677 EXT4_EXTENT_FIRST_INDEX(path_ptr->header) + entries;
678
679 /* Correct entries count because of changes in the previous iteration */
680 if (remove_parent_record) {
681 entries--;
682 }
683
684 /* Iterate over all entries and release the whole subtrees */
685 while (index < stop) {
686 rc = ext4_extent_release_branch(inode_ref, index);
687 if (rc != EOK) {
688 goto cleanup;
689 }
690 ++index;
691 --entries;
692 }
693
694 ext4_extent_header_set_entries_count(path_ptr->header, entries);
695 path_ptr->block->dirty = true;
696
697 /* Free the node if it is empty */
698 if ((entries == 0) && (path_ptr != path)) {
699 rc = ext4_balloc_free_block(inode_ref, path_ptr->block->lba);
700 if (rc != EOK) {
701 goto cleanup;
702 }
703
704 /* Mark parent to be checked */
705 remove_parent_record = true;
706 } else {
707 remove_parent_record = false;
708 }
709
710 --path_ptr;
711 }
712
713
714cleanup:
715 /* Put loaded blocks
716 * starting from 1: 0 is a block with inode data
717 */
718 for (uint16_t i = 1; i <= path->depth; ++i) {
719 if (path[i].block) {
720 block_put(path[i].block);
721 }
722 }
723
724 /* Destroy temporary data structure */
725 free(path);
726
727 return rc;
728}
729
730
731/** Append new extent to the i-node and do some splitting if necessary.
732 *
733 * @param inode_ref i-node to append extent to
734 * @param path path in the extent tree for possible splitting
735 * @param last_path_item input/output parameter for pointer to the last
736 * valid item in the extent tree path
737 * @param iblock logical index of block to append extent for
738 * @return error code
739 */
740static int ext4_extent_append_extent(ext4_inode_ref_t *inode_ref,
741 ext4_extent_path_t *path, ext4_extent_path_t **last_path_item,
742 uint32_t iblock)
743{
744
745 int rc;
746
747 ext4_extent_path_t *path_ptr = *last_path_item;
748
749 uint16_t entries = ext4_extent_header_get_entries_count(path_ptr->header);
750 uint16_t limit = ext4_extent_header_get_max_entries_count(path_ptr->header);
751
752 /* Trivial way - no splitting */
753 if (entries < limit) {
754
755 ext4_extent_header_set_entries_count(path_ptr->header, entries + 1);
756 path_ptr->extent = EXT4_EXTENT_FIRST(path_ptr->header) + entries;
757 ext4_extent_set_block_count(path_ptr->extent, 0);
758 ext4_extent_set_first_block(path_ptr->extent, iblock);
759 ext4_extent_set_start(path_ptr->extent, 0);
760 path_ptr->block->dirty = true;
761
762 return EOK;
763 }
764
765 uint32_t block_size =
766 ext4_superblock_get_block_size(inode_ref->fs->superblock);
767
768 /* Trivial tree - grow (extents were in root node) */
769 if (path_ptr == path) {
770
771 EXT4FS_DBG("splitting root with extents");
772
773 uint32_t new_fblock;
774 rc = ext4_balloc_alloc_block(inode_ref, &new_fblock);
775 if (rc != EOK) {
776 EXT4FS_DBG("error in block allocation");
777 return rc;
778 }
779
780 EXT4FS_DBG("alllocated block \%u for new leaf", new_fblock);
781
782 block_t *block;
783 rc = block_get(&block, inode_ref->fs->device,
784 new_fblock, BLOCK_FLAGS_NOREAD);
785 if (rc != EOK) {
786 EXT4FS_DBG("error in block_get");
787 return rc;
788 }
789
790 memset(block->data, 0, block_size);
791
792 /* Move data from root to the new block */
793 memcpy(block->data, inode_ref->inode->blocks,
794 EXT4_INODE_BLOCKS * sizeof(uint32_t));
795
796 path_ptr++;
797 path_ptr->block = block;
798 path_ptr->header = (ext4_extent_header_t *)block->data;
799 path_ptr->depth = 0;
800 path_ptr->index = NULL;
801
802 uint16_t entries = ext4_extent_header_get_entries_count(path_ptr->header);
803 path_ptr->extent = EXT4_EXTENT_FIRST(path_ptr->header) + entries;
804 ext4_extent_header_set_entries_count(path_ptr->header, entries + 1);
805 uint16_t limit = (block_size - sizeof(ext4_extent_header_t)) /
806 sizeof(ext4_extent_t);
807 ext4_extent_header_set_max_entries_count(path_ptr->header, limit);
808
809 /* Initialize new extent */
810 ext4_extent_set_block_count(path_ptr->extent, 0);
811 ext4_extent_set_first_block(path_ptr->extent, iblock);
812 ext4_extent_set_start(path_ptr->extent, 0);
813
814 /* Modify root (in inode) */
815 path->depth = 1;
816 path->extent = NULL;
817 path->index = EXT4_EXTENT_FIRST_INDEX(path->header);
818
819 ext4_extent_header_set_depth(path->header, 1);
820 ext4_extent_header_set_entries_count(path->header, 1);
821
822 ext4_extent_index_set_first_block(path->index, 0);
823 ext4_extent_index_set_leaf(path->index, new_fblock);
824
825 path_ptr->block->dirty = true;
826 path->block->dirty = true;
827
828 *last_path_item = path_ptr;
829
830
831 ext4_extent_header_t *tmp_root = path->header;
832 EXT4FS_DBG("new root: items = \%u, maximum = \%u, depth = \%u", ext4_extent_header_get_entries_count(tmp_root),
833 ext4_extent_header_get_max_entries_count(tmp_root), ext4_extent_header_get_depth(tmp_root));
834
835 ext4_extent_index_t *root_idx = EXT4_EXTENT_FIRST_INDEX(path->header);
836 EXT4FS_DBG("first iblock = \%u, fblock = \%u", ext4_extent_index_get_first_block(root_idx),
837 (uint32_t)ext4_extent_index_get_leaf(root_idx));
838
839 ext4_extent_header_t *new_leaf = path_ptr->header;
840 EXT4FS_DBG("new leaf: items = \%u, maximum = \%u, depth = \%u", ext4_extent_header_get_entries_count(new_leaf),
841 ext4_extent_header_get_max_entries_count(new_leaf), ext4_extent_header_get_depth(new_leaf));
842
843 for (uint32_t j = 0; j < ext4_extent_header_get_entries_count(new_leaf); ++j) {
844 ext4_extent_t *tmp_ext = EXT4_EXTENT_FIRST(path_ptr->header) + j;
845
846 EXT4FS_DBG("item \%u, first iblock = \%u", j, ext4_extent_get_first_block(tmp_ext));
847 }
848
849
850 EXT4FS_DBG("Root block containing extents was split");
851 return EOK;
852 }
853
854 // TODO !!!
855// assert(false);
856
857 EXT4FS_DBG("More complex splitting");
858
859 /* Start splitting */
860 uint32_t fblock = 0;
861 while (path_ptr > path) {
862
863 // TODO
864
865 rc = ext4_balloc_alloc_block(inode_ref, &fblock);
866 if (rc != EOK) {
867 return rc;
868 }
869
870 block_t *block;
871 rc = block_get(&block, inode_ref->fs->device, fblock, BLOCK_FLAGS_NOREAD);
872 if (rc != EOK) {
873 ext4_balloc_free_block(inode_ref, fblock);
874 return rc;
875 }
876
877 /* Init block */
878 memset(block->data, 0, block_size);
879
880 /* Not modified */
881 block_put(path_ptr->block);
882 path_ptr->block = block;
883
884 path_ptr->header = block->data;
885
886 if (path_ptr->depth) {
887 path_ptr->index = EXT4_EXTENT_FIRST_INDEX(path_ptr->header);
888 } else {
889 path_ptr->extent = EXT4_EXTENT_FIRST(path_ptr->header);
890 }
891
892 path_ptr--;
893 }
894
895 /* If splitting reached root node */
896 if (path_ptr == path) {
897
898 EXT4FS_DBG("Splitting root");
899
900 uint32_t new_fblock;
901 rc = ext4_balloc_alloc_block(inode_ref, &new_fblock);
902 if (rc != EOK) {
903 EXT4FS_DBG("error in block allocation");
904 return rc;
905 }
906
907 block_t *block;
908 rc = block_get(&block, inode_ref->fs->device,
909 new_fblock, BLOCK_FLAGS_NOREAD);
910 if (rc != EOK) {
911 EXT4FS_DBG("error in block_get");
912 return rc;
913 }
914
915 memset(block->data, 0, block_size);
916
917 /* Move data from root to the new block */
918 memcpy(block->data, inode_ref->inode->blocks,
919 EXT4_INODE_BLOCKS * sizeof(uint32_t));
920
921 path_ptr++;
922 path_ptr->block = block;
923 path_ptr->header = (ext4_extent_header_t *)block->data;
924 path_ptr->depth = ext4_extent_header_get_depth(path_ptr->header);
925 path_ptr->index = NULL;
926
927 uint16_t entries = ext4_extent_header_get_entries_count(path_ptr->header);
928 path_ptr->extent = EXT4_EXTENT_FIRST(path_ptr->header) + entries;
929 ext4_extent_header_set_entries_count(path_ptr->header, entries + 1);
930 uint16_t limit = (block_size - sizeof(ext4_extent_header_t)) /
931 sizeof(ext4_extent_t);
932 ext4_extent_header_set_max_entries_count(path_ptr->header, limit);
933
934 /* Modify root (in inode) */
935 path->depth = 1;
936 path->extent = NULL;
937 path->index = EXT4_EXTENT_FIRST_INDEX(path->header);
938
939 ext4_extent_header_set_depth(path->header, path_ptr->depth + 1);
940 ext4_extent_header_set_entries_count(path->header, 1);
941
942 ext4_extent_index_set_first_block(path->index, 0);
943 ext4_extent_index_set_leaf(path->index, new_fblock);
944
945 path_ptr->block->dirty = true;
946 path->block->dirty = true;
947
948 *last_path_item = path_ptr;
949
950 }
951
952 EXT4FS_DBG("Finishing");
953
954 return EOK;
955}
956
957/** Append data block to the i-node.
958 *
959 * This function allocates data block, tries to append it
960 * to some existing extent or creates new extents.
961 * It includes possible extent tree modifications (splitting).
962 *
963 * @param inode_ref i-node to append block to
964 * @param iblock output logical number of newly allocated block
965 * @param fblock output physical block address of newly allocated block
966 * @return error code
967 */
968int ext4_extent_append_block(ext4_inode_ref_t *inode_ref,
969 uint32_t *iblock, uint32_t *fblock, bool update_size)
970{
971 int rc = EOK;
972
973 ext4_superblock_t *sb = inode_ref->fs->superblock;
974 uint64_t inode_size = ext4_inode_get_size(sb, inode_ref->inode);
975 uint32_t block_size = ext4_superblock_get_block_size(sb);
976
977 /* Calculate number of new logical block */
978 uint32_t new_block_idx = 0;
979 if (inode_size > 0) {
980 if ((inode_size % block_size) != 0) {
981 inode_size += block_size - (inode_size % block_size);
982 }
983 new_block_idx = inode_size / block_size;
984 }
985
986 /* Load the nearest leaf (with extent) */
987 ext4_extent_path_t *path;
988 rc = ext4_extent_find_extent(inode_ref, new_block_idx, &path);
989 if (rc != EOK) {
990 return rc;
991 }
992
993 /* Jump to last item of the path (extent) */
994 ext4_extent_path_t *path_ptr = path;
995 while (path_ptr->depth != 0) {
996 path_ptr++;
997 }
998
999 /* Add new extent to the node if not present */
1000 if (path_ptr->extent == NULL) {
1001 goto append_extent;
1002 }
1003
1004 uint16_t block_count = ext4_extent_get_block_count(path_ptr->extent);
1005 uint16_t block_limit = (1 << 15);
1006
1007 uint32_t phys_block = 0;
1008 if (block_count < block_limit) {
1009
1010 /* There is space for new block in the extent */
1011
1012 if (block_count == 0) {
1013
1014 /* Existing extent is empty */
1015
1016 rc = ext4_balloc_alloc_block(inode_ref, &phys_block);
1017 if (rc != EOK) {
1018 goto finish;
1019 }
1020
1021 /* Initialize extent */
1022 ext4_extent_set_first_block(path_ptr->extent, new_block_idx);
1023 ext4_extent_set_start(path_ptr->extent, phys_block);
1024 ext4_extent_set_block_count(path_ptr->extent, 1);
1025
1026 /* Update i-node */
1027 if (update_size) {
1028 ext4_inode_set_size(inode_ref->inode, inode_size + block_size);
1029 inode_ref->dirty = true;
1030 }
1031
1032 path_ptr->block->dirty = true;
1033
1034 goto finish;
1035 } else {
1036
1037 /* Existing extent contains some blocks */
1038
1039 phys_block = ext4_extent_get_start(path_ptr->extent);
1040 phys_block += ext4_extent_get_block_count(path_ptr->extent);
1041
1042 /* Check if the following block is free for allocation */
1043 bool free;
1044 rc = ext4_balloc_try_alloc_block(inode_ref, phys_block, &free);
1045 if (rc != EOK) {
1046 goto finish;
1047 }
1048
1049 if (! free) {
1050 /* target is not free, new block must be appended to new extent */
1051 goto append_extent;
1052 }
1053
1054
1055 /* Update extent */
1056 ext4_extent_set_block_count(path_ptr->extent, block_count + 1);
1057
1058 /* Update i-node */
1059 if (update_size) {
1060 ext4_inode_set_size(inode_ref->inode, inode_size + block_size);
1061 inode_ref->dirty = true;
1062 }
1063
1064 path_ptr->block->dirty = true;
1065
1066 goto finish;
1067 }
1068 }
1069
1070/* Append new extent to the tree */
1071append_extent:
1072
1073 phys_block = 0;
1074
1075 /* Allocate new data block */
1076 rc = ext4_balloc_alloc_block(inode_ref, &phys_block);
1077 if (rc != EOK) {
1078 EXT4FS_DBG("error in block allocation, rc = \%d", rc);
1079 goto finish;
1080 }
1081
1082 /* Append extent for new block (includes tree splitting if needed) */
1083 rc = ext4_extent_append_extent(inode_ref, path, &path_ptr, new_block_idx);
1084 if (rc != EOK) {
1085 ext4_balloc_free_block(inode_ref, phys_block);
1086 goto finish;
1087 }
1088
1089 /* Initialize newly created extent */
1090 ext4_extent_set_block_count(path_ptr->extent, 1);
1091 ext4_extent_set_first_block(path_ptr->extent, new_block_idx);
1092 ext4_extent_set_start(path_ptr->extent, phys_block);
1093
1094 /* Update i-node */
1095 if (update_size) {
1096 ext4_inode_set_size(inode_ref->inode, inode_size + block_size);
1097 inode_ref->dirty = true;
1098 }
1099
1100 path_ptr->block->dirty = true;
1101
1102
1103finish:
1104 /* Set return values */
1105 *iblock = new_block_idx;
1106 *fblock = phys_block;
1107
1108 /* Put loaded blocks
1109 * starting from 1: 0 is a block with inode data
1110 */
1111 for (uint16_t i = 1; i <= path->depth; ++i) {
1112 if (path[i].block) {
1113 block_put(path[i].block);
1114 }
1115 }
1116
1117 /* Destroy temporary data structure */
1118 free(path);
1119
1120 return rc;
1121}
1122
1123/**
1124 * @}
1125 */
Note: See TracBrowser for help on using the repository browser.