| blob | 0ee35c6c9b722ef225e666f63713e4d92cf29be6 |
1 /*
2 * Copyright 2000 by Hans Reiser, licensing governed by reiserfs/README
3 */
5 /**
6 ** old_item_num
7 ** old_entry_num
8 ** set_entry_sizes
9 ** create_virtual_node
10 ** check_left
11 ** check_right
12 ** directory_part_size
13 ** get_num_ver
14 ** set_parameters
15 ** is_leaf_removable
16 ** are_leaves_removable
17 ** get_empty_nodes
18 ** get_lfree
19 ** get_rfree
20 ** is_left_neighbor_in_cache
21 ** decrement_key
22 ** get_far_parent
23 ** get_parents
24 ** can_node_be_removed
25 ** ip_check_balance
26 ** dc_check_balance_internal
27 ** dc_check_balance_leaf
28 ** dc_check_balance
29 ** check_balance
30 ** get_direct_parent
31 ** get_neighbors
32 ** fix_nodes
33 **
34 **
35 **/
37 #include <linux/time.h>
38 #include <linux/string.h>
39 #include <linux/reiserfs_fs.h>
40 #include <linux/buffer_head.h>
42 /* To make any changes in the tree we find a node, that contains item
43 to be changed/deleted or position in the node we insert a new item
44 to. We call this node S. To do balancing we need to decide what we
45 will shift to left/right neighbor, or to a new node, where new item
46 will be etc. To make this analysis simpler we build virtual
47 node. Virtual node is an array of items, that will replace items of
48 node S. (For instance if we are going to delete an item, virtual
49 node does not contain it). Virtual node keeps information about
50 item sizes and types, mergeability of first and last items, sizes
51 of all entries in directory item. We use this array of items when
52 calculating what we can shift to neighbors and how many nodes we
53 have to have if we do not any shiftings, if we shift to left/right
54 neighbor or to both. */
56 /* taking item number in virtual node, returns number of item, that it has in source buffer */
58 {
68 }
72 mode);
73 /* delete mode */
75 }
78 {
86 /* size of changed node */
90 /* for internal nodes array if virtual items is not created */
94 }
96 /* number of items in virtual node */
101 /* first virtual item */
106 /* first item in the node */
109 /* define the mergeability for 0-th item (if it is not being deleted) */
114 /* go through all items those remain in the virtual node (except for the new (inserted) one) */
124 /* get item number in source node */
133 // FIXME: there is no check, that item operation did not
134 // consume too much memory
139 "vs-8030: create_virtual_node: "
143 /* this is not being changed */
149 }
150 }
152 /* virtual inserted item is not defined yet */
165 }
167 /* set right merge flag we take right delimiting key and check whether it is a mergeable item */
176 VI_TYPE_RIGHT_MERGEABLE;
178 #ifdef CONFIG_REISERFS_CHECK
182 /* we delete last item and it could be merged with right neighbor's first item */
187 /* node contains more than 1 item, or item is not directory item, or this item contains more than 1 entry */
193 }
194 }
195 #endif
197 }
198 }
200 /* using virtual node check, how many items can be shifted to left
201 neighbor */
203 {
211 /* internal level */
215 }
217 /* leaf level */
220 /* no free space or nothing to move */
224 }
233 /* all contents of S[0] fits into L[0] */
241 }
245 /* first item may be merge with last item in left neighbor */
254 /* the item can be shifted entirely */
258 }
260 /* the item cannot be shifted entirely, try to split it */
261 /* check whether L[0] can hold ih and at least one byte of the item body */
263 /* cannot shift even a part of the current item */
266 }
271 /* count partially shifted item */
275 }
278 }
280 /* using virtual node check, how many items can be shifted to right
281 neighbor */
283 {
291 /* internal level */
295 }
297 /* leaf level */
300 /* no free space */
304 }
313 /* all contents of S[0] fits into R[0] */
321 }
325 /* last item may be merge with first item in right neighbor */
334 /* the item can be shifted entirely */
338 }
340 /* check whether R[0] can hold ih and at least one byte of the item body */
344 }
346 /* R[0] can hold the header of the item and at least one byte of its body */
351 /* count partially shifted item */
355 }
358 }
360 /*
361 * from - number of items, which are shifted to left neighbor entirely
362 * to - number of item, which are shifted to right neighbor entirely
363 * from_bytes - number of bytes of boundary item (or directory entries) which are shifted to left neighbor
364 * to_bytes - number of bytes of boundary item (or directory entries) which are shifted to right neighbor */
368 {
371 // int bytes;
374 // struct virtual_item * vi;
381 we do not include into node that is being filled */
383 we do node include into node that is being filled */
385 items, that are split between S[0] and
386 S1new and S1new and S2new */
391 /* We only create additional nodes if we are in insert or paste mode
392 or we are in replace mode at the internal level. If h is 0 and
393 the mode is M_REPLACE then in fix_nodes we change the mode to
394 paste or insert before we get here in the code. */
400 /* snum012 [0-2] - number of items, that lay
401 to S[0], first new node and second new node */
405 /* internal level */
411 }
413 /* leaf level */
418 // start from 'from'-th item
420 // skip its first 'start_bytes' units
423 // last included item is the 'end_item'-th one
425 // do not count last 'end_bytes' units of 'end_item'-th item
428 /* go through all item beginning from the start_item-th item and ending by
429 the end_item-th item. Do not count first 'start_bytes' units of
430 'start_item'-th item and last 'end_bytes' of 'end_item'-th item */
438 /* get size of current item */
441 /* do not take in calculation head part (from_bytes) of from-th item */
442 current_item_size -=
445 /* do not take in calculation tail part of last item */
446 current_item_size -=
449 /* if item fits into current node entierly */
455 }
458 /* virtual item length is longer, than max size of item in
459 a node. It is impossible for direct item */
461 "vs-8110: "
464 /* we will try to split it */
466 }
469 /* as we do not split items, take new node and continue */
470 needed_nodes++;
471 i--;
474 }
475 // calculate number of item units which fit into node being
476 // filled
477 {
481 units =
483 skip_from_end);
485 /* nothing fits into current node, take new node and continue */
488 }
489 }
491 /* something fits into the current node */
492 //if (snum012[3] != -1 || needed_nodes != 1)
493 // reiserfs_panic (tb->tb_sb, "vs-8115: get_num_ver: too many nodes required");
494 //snum012[needed_nodes - 1 + 3] = op_unit_num (vi) - start_bytes - units;
503 needed_nodes++;
504 /* continue from the same item with start_bytes != -1 */
506 i--;
508 }
510 // sum012[4] (if it is not -1) contains number of units of which
511 // are to be in S1new, snum012[3] - to be in S0. They are supposed
512 // to be S1bytes and S2bytes correspondingly, so recalculate
519 bytes_to_l =
522 bytes_to_r =
525 bytes_to_S1new =
529 // s2bytes
538 }
540 /* now we know S2bytes, calculate S1bytes */
547 bytes_to_l =
550 bytes_to_r =
553 bytes_to_S2new =
557 // s1bytes
561 }
564 }
566 #ifdef CONFIG_REISERFS_CHECK
568 #endif
570 /* Set parameters for balancing.
571 * Performs write of results of analysis of balancing into structure tb,
572 * where it will later be used by the functions that actually do the balancing.
573 * Parameters:
574 * tb tree_balance structure;
575 * h current level of the node;
576 * lnum number of items from S[h] that must be shifted to L[h];
577 * rnum number of items from S[h] that must be shifted to R[h];
578 * blk_num number of blocks that S[h] will be splitted into;
579 * s012 number of items that fall into splitted nodes.
580 * lbytes number of bytes which flow to the left neighbor from the item that is not
581 * not shifted entirely
582 * rbytes number of bytes which flow to the right neighbor from the item that is not
583 * not shifted entirely
584 * s1bytes number of bytes which flow to the first new node when S[0] splits (this number is contained in s012 array)
585 */
589 {
601 }
604 }
610 }
612 /* check, does node disappear if we shift tb->lnum[0] items to left
613 neighbor and tb->rnum[0] to the right one. */
615 {
621 /* number of items, that will be shifted to left (right) neighbor
622 entirely */
627 /* how many items remain in S[0] after shiftings to neighbors */
631 /* all content of node can be shifted to neighbors */
635 }
638 /* S[0] is not removable */
641 /* check, whether we can divide 1 remaining item between neighbors */
643 /* get size of remaining item (in item units) */
650 }
653 }
655 /* check whether L, S, R can be joined in one node */
657 {
673 /* there was only one item and it will be deleted */
686 /* Directory must be in correct state here: that is
687 somewhere at the left side should exist first directory
688 item. But the item being deleted can not be that first
689 one because its right neighbor is item of the same
690 directory. (But first item always gets deleted in last
691 turn). So, neighbors of deleted item can be merged, so
692 we can save ih_size */
695 /* we might check that left neighbor exists and is of the
696 same directory */
699 }
701 }
707 }
710 }
712 /* when we do not split item, lnum and rnum are numbers of entire items */
713 #define SET_PAR_SHIFT_LEFT \
714 if (h)\
715 {\
716 int to_l;\
717 \
718 to_l = (MAX_NR_KEY(Sh)+1 - lpar + vn->vn_nr_item + 1) / 2 -\
719 (MAX_NR_KEY(Sh) + 1 - lpar);\
720 \
721 set_parameters (tb, h, to_l, 0, lnver, NULL, -1, -1);\
722 }\
723 else \
724 {\
725 if (lset==LEFT_SHIFT_FLOW)\
726 set_parameters (tb, h, lpar, 0, lnver, snum012+lset,\
727 tb->lbytes, -1);\
728 else\
729 set_parameters (tb, h, lpar - (tb->lbytes!=-1), 0, lnver, snum012+lset,\
730 -1, -1);\
731 }
733 #define SET_PAR_SHIFT_RIGHT \
734 if (h)\
735 {\
736 int to_r;\
737 \
738 to_r = (MAX_NR_KEY(Sh)+1 - rpar + vn->vn_nr_item + 1) / 2 - (MAX_NR_KEY(Sh) + 1 - rpar);\
739 \
740 set_parameters (tb, h, 0, to_r, rnver, NULL, -1, -1);\
741 }\
742 else \
743 {\
744 if (rset==RIGHT_SHIFT_FLOW)\
745 set_parameters (tb, h, 0, rpar, rnver, snum012+rset,\
746 -1, tb->rbytes);\
747 else\
748 set_parameters (tb, h, 0, rpar - (tb->rbytes!=-1), rnver, snum012+rset,\
749 -1, -1);\
750 }
753 {
771 }
772 }
774 /* Get new buffers for storing new nodes that are created while balancing.
775 * Returns: SCHEDULE_OCCURRED - schedule occurred while the function worked;
776 * CARRY_ON - schedule didn't occur while the function worked;
777 * NO_DISK_SPACE - no disk space.
778 */
779 /* The function is NOT SCHEDULE-SAFE! */
781 {
789 /* number_of_freeblk is the number of empty blocks which have been
790 acquired for use by the balancing algorithm minus the number of
791 empty blocks used in the previous levels of the analysis,
792 number_of_freeblk = tb->cur_blknum can be non-zero if a schedule occurs
793 after empty blocks are acquired, and the balancing analysis is
794 then restarted, amount_needed is the number needed by this level
795 (n_h) of the balancing analysis.
797 Note that for systems with many processes writing, it would be
798 more layout optimal to calculate the total number needed by all
799 levels and then to run reiserfs_new_blocks to get all of them at once. */
801 /* Initiate number_of_freeblk to the amount acquired prior to the restart of
802 the analysis or 0 if not restarted, then subtract the amount needed
803 by all of the levels of the tree below n_h. */
804 /* blknum includes S[n_h], so we subtract 1 in this calculation */
807 n_number_of_freeblk -=
811 /* Allocate missing empty blocks. */
812 /* if p_s_Sh == 0 then we are getting a new root */
814 /* Amount_needed = the amount that we need more than the amount that we have. */
820 /* No need to check quota - is not allocated for blocks used for formatted nodes */
825 /* for each blocknumber we just got, get a buffer and stick it on FEB */
837 p_s_new_bh);
839 /* Put empty buffers into the array. */
845 }
851 }
853 /* Get free space of the left neighbor, which is stored in the parent
854 * node of the left neighbor. */
856 {
868 }
871 }
873 /* Get free space of the right neighbor,
874 * which is stored in the parent node of the right neighbor.
875 */
877 {
889 }
893 }
895 /* Check whether left neighbor is in memory. */
897 {
900 b_blocknr_t n_left_neighbor_blocknr;
906 /* Calculate father of the node to be balanced. */
917 /* Get position of the pointer to the left neighbor into the left father. */
920 /* Get left neighbor block number. */
921 n_left_neighbor_blocknr =
923 /* Look for the left neighbor in the cache. */
931 }
934 }
940 {
941 // call item specific function for this key
943 }
945 /* Calculate far left/right parent of the left/right neighbor of the current node, that
946 * is calculate the left/right (FL[h]/FR[h]) neighbor of the parent F[h].
947 * Calculate left/right common parent of the current node and L[h]/R[h].
948 * Calculate left/right delimiting key position.
949 * Returns: PATH_INCORRECT - path in the tree is not correct;
950 SCHEDULE_OCCURRED - schedule occurred while the function worked;
951 * CARRY_ON - schedule didn't occur while the function worked;
952 */
957 {
967 /* Starting from F[n_h] go upwards in the tree, and look for the common
968 ancestor of F[n_h], and its neighbor l/r, that should be obtained. */
976 /* Check whether parent of the current buffer in the path is really parent in the tree. */
980 /* Check whether position in the parent is correct. */
986 /* Check whether parent at the path really points to the child. */
990 /* Return delimiting key if position in the parent is not equal to first/last one. */
996 /*(*pp_s_com_father = p_s_parent)->b_count++; */
998 }
999 }
1001 /* if we are in the root of the tree, then there is no common father */
1003 /* Check whether first buffer in the path is the root of the tree. */
1010 }
1012 }
1018 /* Check whether the common parent is locked. */
1025 }
1026 }
1028 /* So, we got common parent of the current node and its left/right neighbor.
1029 Now we are geting the parent of the left/right neighbor. */
1031 /* Form key to get parent of the left/right neighbor. */
1036 n_position -
1039 n_position)));
1047 // path is released
1054 }
1066 }
1068 /* Get parents of neighbors of node in the path(S[n_path_offset]) and common parents of
1069 * S[n_path_offset] and L[n_path_offset]/R[n_path_offset]: F[n_path_offset], FL[n_path_offset],
1070 * FR[n_path_offset], CFL[n_path_offset], CFR[n_path_offset].
1071 * Calculate numbers of left and right delimiting keys position: lkey[n_path_offset], rkey[n_path_offset].
1072 * Returns: SCHEDULE_OCCURRED - schedule occurred while the function worked;
1073 * CARRY_ON - schedule didn't occur while the function worked;
1074 */
1076 {
1079 n_ret_value,
1083 /* Current node is the root of the tree or will be root of the tree */
1085 /* The root can not have parents.
1086 Release nodes which previously were obtained as parents of the current node neighbors. */
1094 }
1096 /* Get parent FL[n_path_offset] of L[n_path_offset]. */
1098 /* Current node is not the first child of its parent. */
1099 /*(p_s_curf = p_s_curcf = PATH_OFFSET_PBUFFER(p_s_path, n_path_offset - 1))->b_count += 2; */
1106 /* Calculate current parent of L[n_path_offset], which is the left neighbor of the current node.
1107 Calculate current common parent of L[n_path_offset] and the current node. Note that
1108 CFL[n_path_offset] not equal FL[n_path_offset] and CFL[n_path_offset] not equal F[n_path_offset].
1109 Calculate lkey[n_path_offset]. */
1114 }
1125 /* Get parent FR[n_h] of R[n_h]. */
1127 /* Current node is the last child of F[n_h]. FR[n_h] != F[n_h]. */
1129 /* Calculate current parent of R[n_h], which is the right neighbor of F[n_h].
1130 Calculate current common parent of R[n_h] and current node. Note that CFR[n_h]
1131 not equal FR[n_path_offset] and CFR[n_h] not equal F[n_h]. */
1137 /* Current node is not the last child of its parent F[n_h]. */
1138 /*(p_s_curf = p_s_curcf = PATH_OFFSET_PBUFFER(p_s_path, n_path_offset - 1))->b_count += 2; */
1144 }
1157 }
1159 /* it is possible to remove node as result of shiftings to
1160 neighbors even when we insert or paste item. */
1163 {
1174 /* shifting may merge items which might save space */
1175 -
1176 ((!h
1178 -
1182 /* node can not be removed */
1190 }
1191 }
1194 }
1196 /* Check whether current node S[h] is balanced when increasing its size by
1197 * Inserting or Pasting.
1198 * Calculate parameters for balancing for current level h.
1199 * Parameters:
1200 * tb tree_balance structure;
1201 * h current level of the node;
1202 * inum item number in S[h];
1203 * mode i - insert, p - paste;
1204 * Returns: 1 - schedule occurred;
1205 * 0 - balancing for higher levels needed;
1206 * -1 - no balancing for higher levels needed;
1207 * -2 - no disk space.
1208 */
1209 /* ip means Inserting or Pasting */
1211 {
1214 is negative if bytes are deleted) buffer which
1215 contains node being balanced. The mnemonic is
1216 that the attempted change in node space used level
1217 is levbytes bytes. */
1218 n_ret_value;
1222 /* nver is short for number of vertixes, and lnver is the number if
1223 we shift to the left, rnver is the number if we shift to the
1224 right, and lrnver is the number if we shift in both directions.
1225 The goal is to minimize first the number of vertixes, and second,
1226 the number of vertixes whose contents are changed by shifting,
1227 and third the number of uncached vertixes whose contents are
1228 changed by shifting and must be read from disk. */
1231 /* used at leaf level only, S0 = S[0] is the node being balanced,
1232 sInum [ I = 0,1,2 ] is the number of items that will
1233 remain in node SI after balancing. S1 and S2 are new
1234 nodes that might be created. */
1236 /* we perform 8 calls to get_num_ver(). For each call we calculate five parameters.
1237 where 4th parameter is s1bytes and 5th - s2bytes
1238 */
1240 0,1 - do not shift and do not shift but bottle
1241 2 - shift only whole item to left
1242 3 - shift to left and bottle as much as possible
1243 4,5 - shift to right (whole items and as much as possible
1244 6,7 - shift to both directions (whole items and as much as possible)
1245 */
1247 /* Sh is the node whose balance is currently being checked */
1253 /* Calculate balance parameters for creating new root. */
1269 }
1270 }
1277 /* get free space of neighbors */
1282 NO_BALANCING_NEEDED)
1283 /* and new item fits into node S[h] without any shifting */
1288 /*
1289 determine maximal number of items we can shift to the left neighbor (in tb structure)
1290 and the maximal number of bytes that can flow to the left neighbor
1291 from the left most liquid item that cannot be shifted from S[0] entirely (returned value)
1292 */
1295 /*
1296 determine maximal number of items we can shift to the right neighbor (in tb structure)
1297 and the maximal number of bytes that can flow to the right neighbor
1298 from the right most liquid item that cannot be shifted from S[0] entirely (returned value)
1299 */
1302 /* all contents of internal node S[h] can be moved into its
1303 neighbors, S[h] will be removed after balancing */
1307 /* Since we are working on internal nodes, and our internal
1308 nodes have fixed size entries, then we can balance by the
1309 number of items rather than the space they consume. In this
1310 routine we set the left node equal to the right node,
1311 allowing a difference of less than or equal to 1 child
1312 pointer. */
1313 to_r =
1320 }
1322 /* this checks balance condition, that any two neighboring nodes can not fit in one node */
1331 /* all contents of S[0] can be moved into its neighbors
1332 S[0] will be removed after balancing. */
1336 /* why do we perform this check here rather than earlier??
1337 Answer: we can win 1 node in some cases above. Moreover we
1338 checked it above, when we checked, that S[0] is not removable
1339 in principle */
1345 }
1347 {
1349 /*
1350 * regular overflowing of the node
1351 */
1353 /* get_num_ver works in 2 modes (FLOW & NO_FLOW)
1354 lpar, rpar - number of items we can shift to left/right neighbor (including splitting item)
1355 nset, lset, rset, lrset - shows, whether flowing items give better packing
1356 */
1357 #define FLOW 1
1360 /* we choose one the following */
1361 #define NOTHING_SHIFT_NO_FLOW 0
1362 #define NOTHING_SHIFT_FLOW 5
1363 #define LEFT_SHIFT_NO_FLOW 10
1364 #define LEFT_SHIFT_FLOW 15
1365 #define RIGHT_SHIFT_NO_FLOW 20
1366 #define RIGHT_SHIFT_FLOW 25
1367 #define LR_SHIFT_NO_FLOW 30
1368 #define LR_SHIFT_FLOW 35
1373 /* calculate number of blocks S[h] must be split into when
1374 nothing is shifted to the neighbors,
1375 as well as number of items in each part of the split node (s012 numbers),
1376 and number of bytes (s1bytes) of the shared drop which flow to S1 if any */
1385 /* note, that in this case we try to bottle between S[0] and S1 (S1 - the first new node) */
1391 }
1393 /* calculate number of blocks S[h] must be split into when
1394 l_shift_num first items and l_shift_bytes of the right most
1395 liquid item to be shifted are shifted to the left neighbor,
1396 as well as number of items in each part of the splitted node (s012 numbers),
1397 and number of bytes (s1bytes) of the shared drop which flow to S1 if any
1398 */
1408 lpar -
1414 }
1416 /* calculate number of blocks S[h] must be split into when
1417 r_shift_num first items and r_shift_bytes of the left most
1418 liquid item to be shifted are shifted to the right neighbor,
1419 as well as number of items in each part of the splitted node (s012 numbers),
1420 and number of bytes (s1bytes) of the shared drop which flow to S1 if any
1421 */
1427 rbytes !=
1443 }
1445 /* calculate number of blocks S[h] must be split into when
1446 items are shifted in both directions,
1447 as well as number of items in each part of the splitted node (s012 numbers),
1448 and number of bytes (s1bytes) of the shared drop which flow to S1 if any
1449 */
1456 rbytes !=
1464 lpar -
1473 }
1475 /* Our general shifting strategy is:
1476 1) to minimized number of new nodes;
1477 2) to minimized number of neighbors involved in shifting;
1478 3) to minimized number of disk reads; */
1480 /* we can win TWO or ONE nodes by shifting in both directions */
1491 else
1500 }
1502 /* if shifting doesn't lead to better packing then don't shift */
1507 }
1509 /* now we know that for better packing shifting in only one
1510 direction either to the left or to the right is required */
1512 /* if shifting to the left is better than shifting to the right */
1514 SET_PAR_SHIFT_LEFT;
1516 }
1518 /* if shifting to the right is better than shifting to the left */
1520 SET_PAR_SHIFT_RIGHT;
1522 }
1524 /* now shifting in either direction gives the same number
1525 of nodes and we can make use of the cached neighbors */
1527 SET_PAR_SHIFT_LEFT;
1529 }
1531 /* shift to the right independently on whether the right neighbor in cache or not */
1532 SET_PAR_SHIFT_RIGHT;
1534 }
1535 }
1537 /* Check whether current node S[h] is balanced when Decreasing its size by
1538 * Deleting or Cutting for INTERNAL node of S+tree.
1539 * Calculate parameters for balancing for current level h.
1540 * Parameters:
1541 * tb tree_balance structure;
1542 * h current level of the node;
1543 * inum item number in S[h];
1544 * mode i - insert, p - paste;
1545 * Returns: 1 - schedule occurred;
1546 * 0 - balancing for higher levels needed;
1547 * -1 - no balancing for higher levels needed;
1548 * -2 - no disk space.
1549 *
1550 * Note: Items of internal nodes have fixed size, so the balance condition for
1551 * the internal part of S+tree is as for the B-trees.
1552 */
1554 {
1557 /* Sh is the node whose balance is currently being checked,
1558 and Fh is its father. */
1568 /* using tb->insert_size[h], which is negative in this case, create_virtual_node calculates: */
1569 /* new_nr_item = number of items node would have if operation is */
1570 /* performed without balancing (new_nr_item); */
1577 }
1578 /* new_nr_item == 0.
1579 * Current root will be deleted resulting in
1580 * decrementing the tree height. */
1583 }
1588 /* get free space of neighbors */
1592 /* determine maximal number of items we can fit into neighbors */
1597 * In this case we balance only if it leads to better packing. */
1599 * which is impossible with greater values of new_nr_item. */
1601 /* All contents of S[h] can be moved to L[h]. */
1605 order_L =
1608 h)) ==
1615 }
1618 /* All contents of S[h] can be moved to R[h]. */
1622 order_R =
1625 h)) ==
1632 }
1633 }
1636 /* All contents of S[h] can be moved to the neighbors (L[h] & R[h]). */
1639 to_r =
1646 }
1648 /* Balancing does not lead to better packing. */
1651 }
1653 /* Current node contain insufficient number of items. Balancing is required. */
1654 /* Check whether we can merge S[h] with left neighbor. */
1661 order_L =
1664 h)) ==
1667 KEY_SIZE);
1670 }
1672 /* Check whether we can merge S[h] with right neighbor. */
1677 order_R =
1682 KEY_SIZE);
1685 }
1687 /* All contents of S[h] can be moved to the neighbors (L[h] & R[h]). */
1691 to_r =
1698 }
1700 /* For internal nodes try to borrow item from a neighbor */
1703 /* Borrow one or two items from caching neighbor */
1707 from_l =
1712 }
1718 }
1720 /* Check whether current node S[h] is balanced when Decreasing its size by
1721 * Deleting or Truncating for LEAF node of S+tree.
1722 * Calculate parameters for balancing for current level h.
1723 * Parameters:
1724 * tb tree_balance structure;
1725 * h current level of the node;
1726 * inum item number in S[h];
1727 * mode i - insert, p - paste;
1728 * Returns: 1 - schedule occurred;
1729 * 0 - balancing for higher levels needed;
1730 * -1 - no balancing for higher levels needed;
1731 * -2 - no disk space.
1732 */
1734 {
1737 /* Number of bytes that must be deleted from
1738 (value is negative if bytes are deleted) buffer which
1739 contains node being balanced. The mnemonic is that the
1740 attempted change in node space used level is levbytes bytes. */
1742 /* the maximal item size */
1744 /* S0 is the node whose balance is currently being checked,
1745 and F0 is its father. */
1763 }
1768 /* get free space of neighbors */
1774 /* if 3 leaves can be merge to one, set parameters and return */
1778 /* determine maximal number of items we can shift to the left/right neighbor
1779 and the maximal number of bytes that can flow to the left/right neighbor
1780 from the left/right most liquid item that cannot be shifted from S[0] entirely
1781 */
1785 /* check whether we can merge S with left neighbor. */
1787 if (is_left_neighbor_in_cache(tb, h) || ((tb->rnum[0] - ((tb->rbytes == -1) ? 0 : 1)) < vn->vn_nr_item) || /* S can not be merged with R */
1793 /* set parameter to merge S[0] with its left neighbor */
1796 }
1798 /* check whether we can merge S[0] with right neighbor. */
1802 }
1804 /* All contents of S[0] can be moved to the neighbors (L[0] & R[0]). Set parameters and return */
1808 /* Balancing is not required. */
1812 }
1814 /* Check whether current node S[h] is balanced when Decreasing its size by
1815 * Deleting or Cutting.
1816 * Calculate parameters for balancing for current level h.
1817 * Parameters:
1818 * tb tree_balance structure;
1819 * h current level of the node;
1820 * inum item number in S[h];
1821 * mode d - delete, c - cut.
1822 * Returns: 1 - schedule occurred;
1823 * 0 - balancing for higher levels needed;
1824 * -1 - no balancing for higher levels needed;
1825 * -2 - no disk space.
1826 */
1828 {
1834 else
1836 }
1838 /* Check whether current node S[h] is balanced.
1839 * Calculate parameters for balancing for current level h.
1840 * Parameters:
1841 *
1842 * tb tree_balance structure:
1843 *
1844 * tb is a large structure that must be read about in the header file
1845 * at the same time as this procedure if the reader is to successfully
1846 * understand this procedure
1847 *
1848 * h current level of the node;
1849 * inum item number in S[h];
1850 * mode i - insert, p - paste, d - delete, c - cut.
1851 * Returns: 1 - schedule occurred;
1852 * 0 - balancing for higher levels needed;
1853 * -1 - no balancing for higher levels needed;
1854 * -2 - no disk space.
1855 */
1862 {
1877 /* Calculate balance parameters when size of node is increasing. */
1880 /* Calculate balance parameters when size of node is decreasing. */
1882 }
1884 /* Check whether parent at the path is the really parent of the current node.*/
1886 {
1892 /* We are in the root or in the new root. */
1900 /* Root is not changed. */
1904 }
1906 }
1919 /* Parent in the path is not parent of the current node in the tree. */
1926 }
1929 }
1931 /* Using lnum[n_h] and rnum[n_h] we should determine what neighbors
1932 * of S[n_h] we
1933 * need in order to balance S[n_h], and get them if necessary.
1934 * Returns: SCHEDULE_OCCURRED - schedule occurred while the function worked;
1935 * CARRY_ON - schedule didn't occur while the function worked;
1936 */
1938 {
1948 /* We need left neighbor to balance S[n_h]. */
1956 n_child_position =
1968 }
1983 }
1991 n_path_offset) >=
1995 n_child_position =
2005 }
2017 }
2019 }
2022 {
2027 #define MIN_NAME_LEN 1
2037 }
2039 /* maybe we should fail balancing we are going to perform when kmalloc
2040 fails several times. But now it will loop until kmalloc gets
2041 required memory */
2043 {
2051 /* we have to allocate more memory for virtual node */
2053 /* free memory allocated before */
2055 /* this is not needed if kfree is atomic */
2057 }
2059 /* virtual node requires now more memory */
2062 /* get memory for virtual item */
2065 /* getting memory with GFP_KERNEL priority may involve
2066 balancing now (due to indirect_to_direct conversion on
2067 dcache shrinking). So, release path and collected
2068 resources here */
2073 }
2077 }
2080 }
2086 }
2088 #ifdef CONFIG_REISERFS_CHECK
2092 {
2097 "jmacd-1: tb_buffer_sanity_check(): negative or zero reference counter for buffer %s[%d] (%b)\n",
2099 }
2105 }
2111 }
2117 }
2123 }
2129 }
2130 }
2131 }
2132 #else
2136 {;
2137 }
2138 #endif
2141 {
2143 }
2146 {
2148 #ifdef CONFIG_REISERFS_CHECK
2150 #endif
2160 /* if I understand correctly, we can only be sure the last buffer
2161 ** in the path is in the tree --clm
2162 */
2163 #ifdef CONFIG_REISERFS_CHECK
2167 PATH_OFFSET_PBUFFER
2172 }
2173 #endif
2175 PATH_OFFSET_PBUFFER
2177 i))) {
2178 locked =
2180 i);
2181 }
2182 }
2183 }
2186 i++) {
2197 }
2206 }
2215 }
2217 }
2228 }
2237 }
2246 }
2247 }
2248 }
2249 /* as far as I can tell, this is not required. The FEB list seems
2250 ** to be full of newly allocated nodes, which will never be locked,
2251 ** dirty, or anything else.
2252 ** To be safe, I'm putting in the checks and waits in. For the moment,
2253 ** they are needed to keep the code in journal.c from complaining
2254 ** about the buffer. That code is inside CONFIG_REISERFS_CHECK as well.
2255 ** --clm
2256 */
2262 }
2263 }
2266 #ifdef CONFIG_REISERFS_CHECK
2267 repeat_counter++;
2270 "wait_tb_buffers_until_released(): too many "
2271 "iterations waiting for buffer to unlock "
2274 /* Don't loop forever. Try to recover from possible error. */
2278 }
2279 #endif
2283 }
2284 }
2289 }
2291 /* Prepare for balancing, that is
2292 * get all necessary parents, and neighbors;
2293 * analyze what and where should be moved;
2294 * get sufficient number of new nodes;
2295 * Balancing will start only after all resources will be collected at a time.
2296 *
2297 * When ported to SMP kernels, only at the last moment after all needed nodes
2298 * are collected in cache, will the resources be locked using the usual
2299 * textbook ordered lock acquisition algorithms. Note that ensuring that
2300 * this code neither write locks what it does not need to write lock nor locks out of order
2301 * will be a pain in the butt that could have been avoided. Grumble grumble. -Hans
2302 *
2303 * fix is meant in the sense of render unchanging
2304 *
2305 * Latency might be improved by first gathering a list of what buffers are needed
2306 * and then getting as many of them in parallel as possible? -Hans
2307 *
2308 * Parameters:
2309 * op_mode i - insert, d - delete, c - cut (truncate), p - paste (append)
2310 * tb tree_balance structure;
2311 * inum item number in S[h];
2312 * pos_in_item - comment this if you can
2313 * ins_ih & ins_sd are used when inserting
2314 * Returns: 1 - schedule occurred while the function worked;
2315 * 0 - schedule didn't occur while the function worked;
2316 * -1 - if no_disk_space
2317 */
2319 int fix_nodes(int n_op_mode, struct tree_balance *p_s_tb, struct item_head *p_s_ins_ih, // item head of item being inserted
2321 )
2322 {
2326 /* we set wait_tb_buffers_run when we have to restore any dirty bits cleared
2327 ** during wait_tb_buffers_run
2328 */
2338 /* we prepare and log the super here so it will already be in the
2339 ** transaction when do_balance needs to change it.
2340 ** This way do_balance won't have to schedule when trying to prepare
2341 ** the super for logging
2342 */
2350 /* if it possible in indirect_to_direct conversion */
2355 }
2356 #ifdef CONFIG_REISERFS_CHECK
2361 }
2365 "PAP-8320: fix_nodes: S[0] (%b %z) is not uptodate "
2368 }
2370 /* Check parameters. */
2387 }
2392 }
2393 #endif
2396 // FIXME: maybe -ENOMEM when tb->vn_buf == 0? Now just repeat
2399 /* Starting from the leaf level; for all levels n_h of the tree. */
2403 }
2410 /* No balancing for higher levels needed. */
2414 }
2417 /* ok, analysis and resource gathering are complete */
2419 }
2421 }
2425 }
2429 analysis may be invalid and needs to be redone. */
2430 }
2433 /* We have a positive insert size but no nodes exist on this
2434 level, this means that we are creating a new root. */
2443 /* The tree needs to be grown, so this node S[n_h]
2444 which is the root node is split into two nodes,
2445 and a new node (S[n_h+1]) will be created to
2446 become the root node. */
2454 DC_SIZE;
2460 }
2469 }
2473 }
2475 repeat:
2476 // fix_nodes was unable to perform its calculation due to
2477 // filesystem got changed under us, lack of free disk space or i/o
2478 // failure. If the first is the case - the search will be
2479 // repeated. For now - free all resources acquired so far except
2480 // for the new allocated nodes
2481 {
2484 /* Release path buffers. */
2489 }
2490 /* brelse all resources collected for balancing */
2502 p_s_tb->
2505 p_s_tb->
2507 }
2521 }
2526 reiserfs_restore_prepared_buffer
2528 }
2529 }
2530 }
2532 }
2534 }
2536 /* Anatoly will probably forgive me renaming p_s_tb to tb. I just
2537 wanted to make lines shorter */
2539 {
2542 /* Release path buffers. */
2545 /* brelse all resources collected for balancing */
2560 }
2562 /* deal with list of allocated (used and unused) nodes */
2566 /* de-allocated block which was not used by balancing and
2567 bforget about buffer for it */
2571 }
2573 /* release used as new nodes including a new root */
2575 }
2576 }
2580 }