1*4882a593Smuzhiyun /*
2*4882a593Smuzhiyun * Copyright 2000 by Hans Reiser, licensing governed by reiserfs/README
3*4882a593Smuzhiyun */
4*4882a593Smuzhiyun
5*4882a593Smuzhiyun /*
6*4882a593Smuzhiyun * Now we have all buffers that must be used in balancing of the tree
7*4882a593Smuzhiyun * Further calculations can not cause schedule(), and thus the buffer
8*4882a593Smuzhiyun * tree will be stable until the balancing will be finished
9*4882a593Smuzhiyun * balance the tree according to the analysis made before,
10*4882a593Smuzhiyun * and using buffers obtained after all above.
11*4882a593Smuzhiyun */
12*4882a593Smuzhiyun
13*4882a593Smuzhiyun #include <linux/uaccess.h>
14*4882a593Smuzhiyun #include <linux/time.h>
15*4882a593Smuzhiyun #include "reiserfs.h"
16*4882a593Smuzhiyun #include <linux/buffer_head.h>
17*4882a593Smuzhiyun #include <linux/kernel.h>
18*4882a593Smuzhiyun
buffer_info_init_left(struct tree_balance * tb,struct buffer_info * bi)19*4882a593Smuzhiyun static inline void buffer_info_init_left(struct tree_balance *tb,
20*4882a593Smuzhiyun struct buffer_info *bi)
21*4882a593Smuzhiyun {
22*4882a593Smuzhiyun bi->tb = tb;
23*4882a593Smuzhiyun bi->bi_bh = tb->L[0];
24*4882a593Smuzhiyun bi->bi_parent = tb->FL[0];
25*4882a593Smuzhiyun bi->bi_position = get_left_neighbor_position(tb, 0);
26*4882a593Smuzhiyun }
27*4882a593Smuzhiyun
buffer_info_init_right(struct tree_balance * tb,struct buffer_info * bi)28*4882a593Smuzhiyun static inline void buffer_info_init_right(struct tree_balance *tb,
29*4882a593Smuzhiyun struct buffer_info *bi)
30*4882a593Smuzhiyun {
31*4882a593Smuzhiyun bi->tb = tb;
32*4882a593Smuzhiyun bi->bi_bh = tb->R[0];
33*4882a593Smuzhiyun bi->bi_parent = tb->FR[0];
34*4882a593Smuzhiyun bi->bi_position = get_right_neighbor_position(tb, 0);
35*4882a593Smuzhiyun }
36*4882a593Smuzhiyun
buffer_info_init_tbS0(struct tree_balance * tb,struct buffer_info * bi)37*4882a593Smuzhiyun static inline void buffer_info_init_tbS0(struct tree_balance *tb,
38*4882a593Smuzhiyun struct buffer_info *bi)
39*4882a593Smuzhiyun {
40*4882a593Smuzhiyun bi->tb = tb;
41*4882a593Smuzhiyun bi->bi_bh = PATH_PLAST_BUFFER(tb->tb_path);
42*4882a593Smuzhiyun bi->bi_parent = PATH_H_PPARENT(tb->tb_path, 0);
43*4882a593Smuzhiyun bi->bi_position = PATH_H_POSITION(tb->tb_path, 1);
44*4882a593Smuzhiyun }
45*4882a593Smuzhiyun
buffer_info_init_bh(struct tree_balance * tb,struct buffer_info * bi,struct buffer_head * bh)46*4882a593Smuzhiyun static inline void buffer_info_init_bh(struct tree_balance *tb,
47*4882a593Smuzhiyun struct buffer_info *bi,
48*4882a593Smuzhiyun struct buffer_head *bh)
49*4882a593Smuzhiyun {
50*4882a593Smuzhiyun bi->tb = tb;
51*4882a593Smuzhiyun bi->bi_bh = bh;
52*4882a593Smuzhiyun bi->bi_parent = NULL;
53*4882a593Smuzhiyun bi->bi_position = 0;
54*4882a593Smuzhiyun }
55*4882a593Smuzhiyun
do_balance_mark_leaf_dirty(struct tree_balance * tb,struct buffer_head * bh,int flag)56*4882a593Smuzhiyun inline void do_balance_mark_leaf_dirty(struct tree_balance *tb,
57*4882a593Smuzhiyun struct buffer_head *bh, int flag)
58*4882a593Smuzhiyun {
59*4882a593Smuzhiyun journal_mark_dirty(tb->transaction_handle, bh);
60*4882a593Smuzhiyun }
61*4882a593Smuzhiyun
62*4882a593Smuzhiyun #define do_balance_mark_internal_dirty do_balance_mark_leaf_dirty
63*4882a593Smuzhiyun #define do_balance_mark_sb_dirty do_balance_mark_leaf_dirty
64*4882a593Smuzhiyun
65*4882a593Smuzhiyun /*
66*4882a593Smuzhiyun * summary:
67*4882a593Smuzhiyun * if deleting something ( tb->insert_size[0] < 0 )
68*4882a593Smuzhiyun * return(balance_leaf_when_delete()); (flag d handled here)
69*4882a593Smuzhiyun * else
70*4882a593Smuzhiyun * if lnum is larger than 0 we put items into the left node
71*4882a593Smuzhiyun * if rnum is larger than 0 we put items into the right node
72*4882a593Smuzhiyun * if snum1 is larger than 0 we put items into the new node s1
73*4882a593Smuzhiyun * if snum2 is larger than 0 we put items into the new node s2
74*4882a593Smuzhiyun * Note that all *num* count new items being created.
75*4882a593Smuzhiyun */
76*4882a593Smuzhiyun
balance_leaf_when_delete_del(struct tree_balance * tb)77*4882a593Smuzhiyun static void balance_leaf_when_delete_del(struct tree_balance *tb)
78*4882a593Smuzhiyun {
79*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
80*4882a593Smuzhiyun int item_pos = PATH_LAST_POSITION(tb->tb_path);
81*4882a593Smuzhiyun struct buffer_info bi;
82*4882a593Smuzhiyun #ifdef CONFIG_REISERFS_CHECK
83*4882a593Smuzhiyun struct item_head *ih = item_head(tbS0, item_pos);
84*4882a593Smuzhiyun #endif
85*4882a593Smuzhiyun
86*4882a593Smuzhiyun RFALSE(ih_item_len(ih) + IH_SIZE != -tb->insert_size[0],
87*4882a593Smuzhiyun "vs-12013: mode Delete, insert size %d, ih to be deleted %h",
88*4882a593Smuzhiyun -tb->insert_size[0], ih);
89*4882a593Smuzhiyun
90*4882a593Smuzhiyun buffer_info_init_tbS0(tb, &bi);
91*4882a593Smuzhiyun leaf_delete_items(&bi, 0, item_pos, 1, -1);
92*4882a593Smuzhiyun
93*4882a593Smuzhiyun if (!item_pos && tb->CFL[0]) {
94*4882a593Smuzhiyun if (B_NR_ITEMS(tbS0)) {
95*4882a593Smuzhiyun replace_key(tb, tb->CFL[0], tb->lkey[0], tbS0, 0);
96*4882a593Smuzhiyun } else {
97*4882a593Smuzhiyun if (!PATH_H_POSITION(tb->tb_path, 1))
98*4882a593Smuzhiyun replace_key(tb, tb->CFL[0], tb->lkey[0],
99*4882a593Smuzhiyun PATH_H_PPARENT(tb->tb_path, 0), 0);
100*4882a593Smuzhiyun }
101*4882a593Smuzhiyun }
102*4882a593Smuzhiyun
103*4882a593Smuzhiyun RFALSE(!item_pos && !tb->CFL[0],
104*4882a593Smuzhiyun "PAP-12020: tb->CFL[0]==%p, tb->L[0]==%p", tb->CFL[0],
105*4882a593Smuzhiyun tb->L[0]);
106*4882a593Smuzhiyun }
107*4882a593Smuzhiyun
108*4882a593Smuzhiyun /* cut item in S[0] */
balance_leaf_when_delete_cut(struct tree_balance * tb)109*4882a593Smuzhiyun static void balance_leaf_when_delete_cut(struct tree_balance *tb)
110*4882a593Smuzhiyun {
111*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
112*4882a593Smuzhiyun int item_pos = PATH_LAST_POSITION(tb->tb_path);
113*4882a593Smuzhiyun struct item_head *ih = item_head(tbS0, item_pos);
114*4882a593Smuzhiyun int pos_in_item = tb->tb_path->pos_in_item;
115*4882a593Smuzhiyun struct buffer_info bi;
116*4882a593Smuzhiyun buffer_info_init_tbS0(tb, &bi);
117*4882a593Smuzhiyun
118*4882a593Smuzhiyun if (is_direntry_le_ih(ih)) {
119*4882a593Smuzhiyun /*
120*4882a593Smuzhiyun * UFS unlink semantics are such that you can only
121*4882a593Smuzhiyun * delete one directory entry at a time.
122*4882a593Smuzhiyun *
123*4882a593Smuzhiyun * when we cut a directory tb->insert_size[0] means
124*4882a593Smuzhiyun * number of entries to be cut (always 1)
125*4882a593Smuzhiyun */
126*4882a593Smuzhiyun tb->insert_size[0] = -1;
127*4882a593Smuzhiyun leaf_cut_from_buffer(&bi, item_pos, pos_in_item,
128*4882a593Smuzhiyun -tb->insert_size[0]);
129*4882a593Smuzhiyun
130*4882a593Smuzhiyun RFALSE(!item_pos && !pos_in_item && !tb->CFL[0],
131*4882a593Smuzhiyun "PAP-12030: can not change delimiting key. CFL[0]=%p",
132*4882a593Smuzhiyun tb->CFL[0]);
133*4882a593Smuzhiyun
134*4882a593Smuzhiyun if (!item_pos && !pos_in_item && tb->CFL[0])
135*4882a593Smuzhiyun replace_key(tb, tb->CFL[0], tb->lkey[0], tbS0, 0);
136*4882a593Smuzhiyun } else {
137*4882a593Smuzhiyun leaf_cut_from_buffer(&bi, item_pos, pos_in_item,
138*4882a593Smuzhiyun -tb->insert_size[0]);
139*4882a593Smuzhiyun
140*4882a593Smuzhiyun RFALSE(!ih_item_len(ih),
141*4882a593Smuzhiyun "PAP-12035: cut must leave non-zero dynamic "
142*4882a593Smuzhiyun "length of item");
143*4882a593Smuzhiyun }
144*4882a593Smuzhiyun }
145*4882a593Smuzhiyun
balance_leaf_when_delete_left(struct tree_balance * tb)146*4882a593Smuzhiyun static int balance_leaf_when_delete_left(struct tree_balance *tb)
147*4882a593Smuzhiyun {
148*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
149*4882a593Smuzhiyun int n = B_NR_ITEMS(tbS0);
150*4882a593Smuzhiyun
151*4882a593Smuzhiyun /* L[0] must be joined with S[0] */
152*4882a593Smuzhiyun if (tb->lnum[0] == -1) {
153*4882a593Smuzhiyun /* R[0] must be also joined with S[0] */
154*4882a593Smuzhiyun if (tb->rnum[0] == -1) {
155*4882a593Smuzhiyun if (tb->FR[0] == PATH_H_PPARENT(tb->tb_path, 0)) {
156*4882a593Smuzhiyun /*
157*4882a593Smuzhiyun * all contents of all the
158*4882a593Smuzhiyun * 3 buffers will be in L[0]
159*4882a593Smuzhiyun */
160*4882a593Smuzhiyun if (PATH_H_POSITION(tb->tb_path, 1) == 0 &&
161*4882a593Smuzhiyun 1 < B_NR_ITEMS(tb->FR[0]))
162*4882a593Smuzhiyun replace_key(tb, tb->CFL[0],
163*4882a593Smuzhiyun tb->lkey[0], tb->FR[0], 1);
164*4882a593Smuzhiyun
165*4882a593Smuzhiyun leaf_move_items(LEAF_FROM_S_TO_L, tb, n, -1,
166*4882a593Smuzhiyun NULL);
167*4882a593Smuzhiyun leaf_move_items(LEAF_FROM_R_TO_L, tb,
168*4882a593Smuzhiyun B_NR_ITEMS(tb->R[0]), -1,
169*4882a593Smuzhiyun NULL);
170*4882a593Smuzhiyun
171*4882a593Smuzhiyun reiserfs_invalidate_buffer(tb, tbS0);
172*4882a593Smuzhiyun reiserfs_invalidate_buffer(tb, tb->R[0]);
173*4882a593Smuzhiyun
174*4882a593Smuzhiyun return 0;
175*4882a593Smuzhiyun }
176*4882a593Smuzhiyun
177*4882a593Smuzhiyun /* all contents of all the 3 buffers will be in R[0] */
178*4882a593Smuzhiyun leaf_move_items(LEAF_FROM_S_TO_R, tb, n, -1, NULL);
179*4882a593Smuzhiyun leaf_move_items(LEAF_FROM_L_TO_R, tb,
180*4882a593Smuzhiyun B_NR_ITEMS(tb->L[0]), -1, NULL);
181*4882a593Smuzhiyun
182*4882a593Smuzhiyun /* right_delimiting_key is correct in R[0] */
183*4882a593Smuzhiyun replace_key(tb, tb->CFR[0], tb->rkey[0], tb->R[0], 0);
184*4882a593Smuzhiyun
185*4882a593Smuzhiyun reiserfs_invalidate_buffer(tb, tbS0);
186*4882a593Smuzhiyun reiserfs_invalidate_buffer(tb, tb->L[0]);
187*4882a593Smuzhiyun
188*4882a593Smuzhiyun return -1;
189*4882a593Smuzhiyun }
190*4882a593Smuzhiyun
191*4882a593Smuzhiyun RFALSE(tb->rnum[0] != 0,
192*4882a593Smuzhiyun "PAP-12045: rnum must be 0 (%d)", tb->rnum[0]);
193*4882a593Smuzhiyun /* all contents of L[0] and S[0] will be in L[0] */
194*4882a593Smuzhiyun leaf_shift_left(tb, n, -1);
195*4882a593Smuzhiyun
196*4882a593Smuzhiyun reiserfs_invalidate_buffer(tb, tbS0);
197*4882a593Smuzhiyun
198*4882a593Smuzhiyun return 0;
199*4882a593Smuzhiyun }
200*4882a593Smuzhiyun
201*4882a593Smuzhiyun /*
202*4882a593Smuzhiyun * a part of contents of S[0] will be in L[0] and
203*4882a593Smuzhiyun * the rest part of S[0] will be in R[0]
204*4882a593Smuzhiyun */
205*4882a593Smuzhiyun
206*4882a593Smuzhiyun RFALSE((tb->lnum[0] + tb->rnum[0] < n) ||
207*4882a593Smuzhiyun (tb->lnum[0] + tb->rnum[0] > n + 1),
208*4882a593Smuzhiyun "PAP-12050: rnum(%d) and lnum(%d) and item "
209*4882a593Smuzhiyun "number(%d) in S[0] are not consistent",
210*4882a593Smuzhiyun tb->rnum[0], tb->lnum[0], n);
211*4882a593Smuzhiyun RFALSE((tb->lnum[0] + tb->rnum[0] == n) &&
212*4882a593Smuzhiyun (tb->lbytes != -1 || tb->rbytes != -1),
213*4882a593Smuzhiyun "PAP-12055: bad rbytes (%d)/lbytes (%d) "
214*4882a593Smuzhiyun "parameters when items are not split",
215*4882a593Smuzhiyun tb->rbytes, tb->lbytes);
216*4882a593Smuzhiyun RFALSE((tb->lnum[0] + tb->rnum[0] == n + 1) &&
217*4882a593Smuzhiyun (tb->lbytes < 1 || tb->rbytes != -1),
218*4882a593Smuzhiyun "PAP-12060: bad rbytes (%d)/lbytes (%d) "
219*4882a593Smuzhiyun "parameters when items are split",
220*4882a593Smuzhiyun tb->rbytes, tb->lbytes);
221*4882a593Smuzhiyun
222*4882a593Smuzhiyun leaf_shift_left(tb, tb->lnum[0], tb->lbytes);
223*4882a593Smuzhiyun leaf_shift_right(tb, tb->rnum[0], tb->rbytes);
224*4882a593Smuzhiyun
225*4882a593Smuzhiyun reiserfs_invalidate_buffer(tb, tbS0);
226*4882a593Smuzhiyun
227*4882a593Smuzhiyun return 0;
228*4882a593Smuzhiyun }
229*4882a593Smuzhiyun
230*4882a593Smuzhiyun /*
231*4882a593Smuzhiyun * Balance leaf node in case of delete or cut: insert_size[0] < 0
232*4882a593Smuzhiyun *
233*4882a593Smuzhiyun * lnum, rnum can have values >= -1
234*4882a593Smuzhiyun * -1 means that the neighbor must be joined with S
235*4882a593Smuzhiyun * 0 means that nothing should be done with the neighbor
236*4882a593Smuzhiyun * >0 means to shift entirely or partly the specified number of items
237*4882a593Smuzhiyun * to the neighbor
238*4882a593Smuzhiyun */
balance_leaf_when_delete(struct tree_balance * tb,int flag)239*4882a593Smuzhiyun static int balance_leaf_when_delete(struct tree_balance *tb, int flag)
240*4882a593Smuzhiyun {
241*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
242*4882a593Smuzhiyun struct buffer_info bi;
243*4882a593Smuzhiyun int n;
244*4882a593Smuzhiyun
245*4882a593Smuzhiyun RFALSE(tb->FR[0] && B_LEVEL(tb->FR[0]) != DISK_LEAF_NODE_LEVEL + 1,
246*4882a593Smuzhiyun "vs- 12000: level: wrong FR %z", tb->FR[0]);
247*4882a593Smuzhiyun RFALSE(tb->blknum[0] > 1,
248*4882a593Smuzhiyun "PAP-12005: tb->blknum == %d, can not be > 1", tb->blknum[0]);
249*4882a593Smuzhiyun RFALSE(!tb->blknum[0] && !PATH_H_PPARENT(tb->tb_path, 0),
250*4882a593Smuzhiyun "PAP-12010: tree can not be empty");
251*4882a593Smuzhiyun
252*4882a593Smuzhiyun buffer_info_init_tbS0(tb, &bi);
253*4882a593Smuzhiyun
254*4882a593Smuzhiyun /* Delete or truncate the item */
255*4882a593Smuzhiyun
256*4882a593Smuzhiyun BUG_ON(flag != M_DELETE && flag != M_CUT);
257*4882a593Smuzhiyun if (flag == M_DELETE)
258*4882a593Smuzhiyun balance_leaf_when_delete_del(tb);
259*4882a593Smuzhiyun else /* M_CUT */
260*4882a593Smuzhiyun balance_leaf_when_delete_cut(tb);
261*4882a593Smuzhiyun
262*4882a593Smuzhiyun
263*4882a593Smuzhiyun /*
264*4882a593Smuzhiyun * the rule is that no shifting occurs unless by shifting
265*4882a593Smuzhiyun * a node can be freed
266*4882a593Smuzhiyun */
267*4882a593Smuzhiyun n = B_NR_ITEMS(tbS0);
268*4882a593Smuzhiyun
269*4882a593Smuzhiyun
270*4882a593Smuzhiyun /* L[0] takes part in balancing */
271*4882a593Smuzhiyun if (tb->lnum[0])
272*4882a593Smuzhiyun return balance_leaf_when_delete_left(tb);
273*4882a593Smuzhiyun
274*4882a593Smuzhiyun if (tb->rnum[0] == -1) {
275*4882a593Smuzhiyun /* all contents of R[0] and S[0] will be in R[0] */
276*4882a593Smuzhiyun leaf_shift_right(tb, n, -1);
277*4882a593Smuzhiyun reiserfs_invalidate_buffer(tb, tbS0);
278*4882a593Smuzhiyun return 0;
279*4882a593Smuzhiyun }
280*4882a593Smuzhiyun
281*4882a593Smuzhiyun RFALSE(tb->rnum[0],
282*4882a593Smuzhiyun "PAP-12065: bad rnum parameter must be 0 (%d)", tb->rnum[0]);
283*4882a593Smuzhiyun return 0;
284*4882a593Smuzhiyun }
285*4882a593Smuzhiyun
balance_leaf_insert_left(struct tree_balance * tb,struct item_head * const ih,const char * const body)286*4882a593Smuzhiyun static unsigned int balance_leaf_insert_left(struct tree_balance *tb,
287*4882a593Smuzhiyun struct item_head *const ih,
288*4882a593Smuzhiyun const char * const body)
289*4882a593Smuzhiyun {
290*4882a593Smuzhiyun int ret;
291*4882a593Smuzhiyun struct buffer_info bi;
292*4882a593Smuzhiyun int n = B_NR_ITEMS(tb->L[0]);
293*4882a593Smuzhiyun unsigned body_shift_bytes = 0;
294*4882a593Smuzhiyun
295*4882a593Smuzhiyun if (tb->item_pos == tb->lnum[0] - 1 && tb->lbytes != -1) {
296*4882a593Smuzhiyun /* part of new item falls into L[0] */
297*4882a593Smuzhiyun int new_item_len, shift;
298*4882a593Smuzhiyun
299*4882a593Smuzhiyun ret = leaf_shift_left(tb, tb->lnum[0] - 1, -1);
300*4882a593Smuzhiyun
301*4882a593Smuzhiyun /* Calculate item length to insert to S[0] */
302*4882a593Smuzhiyun new_item_len = ih_item_len(ih) - tb->lbytes;
303*4882a593Smuzhiyun
304*4882a593Smuzhiyun /* Calculate and check item length to insert to L[0] */
305*4882a593Smuzhiyun put_ih_item_len(ih, ih_item_len(ih) - new_item_len);
306*4882a593Smuzhiyun
307*4882a593Smuzhiyun RFALSE(ih_item_len(ih) <= 0,
308*4882a593Smuzhiyun "PAP-12080: there is nothing to insert into L[0]: "
309*4882a593Smuzhiyun "ih_item_len=%d", ih_item_len(ih));
310*4882a593Smuzhiyun
311*4882a593Smuzhiyun /* Insert new item into L[0] */
312*4882a593Smuzhiyun buffer_info_init_left(tb, &bi);
313*4882a593Smuzhiyun leaf_insert_into_buf(&bi, n + tb->item_pos - ret, ih, body,
314*4882a593Smuzhiyun min_t(int, tb->zeroes_num, ih_item_len(ih)));
315*4882a593Smuzhiyun
316*4882a593Smuzhiyun /*
317*4882a593Smuzhiyun * Calculate key component, item length and body to
318*4882a593Smuzhiyun * insert into S[0]
319*4882a593Smuzhiyun */
320*4882a593Smuzhiyun shift = 0;
321*4882a593Smuzhiyun if (is_indirect_le_ih(ih))
322*4882a593Smuzhiyun shift = tb->tb_sb->s_blocksize_bits - UNFM_P_SHIFT;
323*4882a593Smuzhiyun
324*4882a593Smuzhiyun add_le_ih_k_offset(ih, tb->lbytes << shift);
325*4882a593Smuzhiyun
326*4882a593Smuzhiyun put_ih_item_len(ih, new_item_len);
327*4882a593Smuzhiyun if (tb->lbytes > tb->zeroes_num) {
328*4882a593Smuzhiyun body_shift_bytes = tb->lbytes - tb->zeroes_num;
329*4882a593Smuzhiyun tb->zeroes_num = 0;
330*4882a593Smuzhiyun } else
331*4882a593Smuzhiyun tb->zeroes_num -= tb->lbytes;
332*4882a593Smuzhiyun
333*4882a593Smuzhiyun RFALSE(ih_item_len(ih) <= 0,
334*4882a593Smuzhiyun "PAP-12085: there is nothing to insert into S[0]: "
335*4882a593Smuzhiyun "ih_item_len=%d", ih_item_len(ih));
336*4882a593Smuzhiyun } else {
337*4882a593Smuzhiyun /* new item in whole falls into L[0] */
338*4882a593Smuzhiyun /* Shift lnum[0]-1 items to L[0] */
339*4882a593Smuzhiyun ret = leaf_shift_left(tb, tb->lnum[0] - 1, tb->lbytes);
340*4882a593Smuzhiyun
341*4882a593Smuzhiyun /* Insert new item into L[0] */
342*4882a593Smuzhiyun buffer_info_init_left(tb, &bi);
343*4882a593Smuzhiyun leaf_insert_into_buf(&bi, n + tb->item_pos - ret, ih, body,
344*4882a593Smuzhiyun tb->zeroes_num);
345*4882a593Smuzhiyun tb->insert_size[0] = 0;
346*4882a593Smuzhiyun tb->zeroes_num = 0;
347*4882a593Smuzhiyun }
348*4882a593Smuzhiyun return body_shift_bytes;
349*4882a593Smuzhiyun }
350*4882a593Smuzhiyun
balance_leaf_paste_left_shift_dirent(struct tree_balance * tb,struct item_head * const ih,const char * const body)351*4882a593Smuzhiyun static void balance_leaf_paste_left_shift_dirent(struct tree_balance *tb,
352*4882a593Smuzhiyun struct item_head * const ih,
353*4882a593Smuzhiyun const char * const body)
354*4882a593Smuzhiyun {
355*4882a593Smuzhiyun int n = B_NR_ITEMS(tb->L[0]);
356*4882a593Smuzhiyun struct buffer_info bi;
357*4882a593Smuzhiyun
358*4882a593Smuzhiyun RFALSE(tb->zeroes_num,
359*4882a593Smuzhiyun "PAP-12090: invalid parameter in case of a directory");
360*4882a593Smuzhiyun
361*4882a593Smuzhiyun /* directory item */
362*4882a593Smuzhiyun if (tb->lbytes > tb->pos_in_item) {
363*4882a593Smuzhiyun /* new directory entry falls into L[0] */
364*4882a593Smuzhiyun struct item_head *pasted;
365*4882a593Smuzhiyun int ret, l_pos_in_item = tb->pos_in_item;
366*4882a593Smuzhiyun
367*4882a593Smuzhiyun /*
368*4882a593Smuzhiyun * Shift lnum[0] - 1 items in whole.
369*4882a593Smuzhiyun * Shift lbytes - 1 entries from given directory item
370*4882a593Smuzhiyun */
371*4882a593Smuzhiyun ret = leaf_shift_left(tb, tb->lnum[0], tb->lbytes - 1);
372*4882a593Smuzhiyun if (ret && !tb->item_pos) {
373*4882a593Smuzhiyun pasted = item_head(tb->L[0], B_NR_ITEMS(tb->L[0]) - 1);
374*4882a593Smuzhiyun l_pos_in_item += ih_entry_count(pasted) -
375*4882a593Smuzhiyun (tb->lbytes - 1);
376*4882a593Smuzhiyun }
377*4882a593Smuzhiyun
378*4882a593Smuzhiyun /* Append given directory entry to directory item */
379*4882a593Smuzhiyun buffer_info_init_left(tb, &bi);
380*4882a593Smuzhiyun leaf_paste_in_buffer(&bi, n + tb->item_pos - ret,
381*4882a593Smuzhiyun l_pos_in_item, tb->insert_size[0],
382*4882a593Smuzhiyun body, tb->zeroes_num);
383*4882a593Smuzhiyun
384*4882a593Smuzhiyun /*
385*4882a593Smuzhiyun * previous string prepared space for pasting new entry,
386*4882a593Smuzhiyun * following string pastes this entry
387*4882a593Smuzhiyun */
388*4882a593Smuzhiyun
389*4882a593Smuzhiyun /*
390*4882a593Smuzhiyun * when we have merge directory item, pos_in_item
391*4882a593Smuzhiyun * has been changed too
392*4882a593Smuzhiyun */
393*4882a593Smuzhiyun
394*4882a593Smuzhiyun /* paste new directory entry. 1 is entry number */
395*4882a593Smuzhiyun leaf_paste_entries(&bi, n + tb->item_pos - ret,
396*4882a593Smuzhiyun l_pos_in_item, 1,
397*4882a593Smuzhiyun (struct reiserfs_de_head *) body,
398*4882a593Smuzhiyun body + DEH_SIZE, tb->insert_size[0]);
399*4882a593Smuzhiyun tb->insert_size[0] = 0;
400*4882a593Smuzhiyun } else {
401*4882a593Smuzhiyun /* new directory item doesn't fall into L[0] */
402*4882a593Smuzhiyun /*
403*4882a593Smuzhiyun * Shift lnum[0]-1 items in whole. Shift lbytes
404*4882a593Smuzhiyun * directory entries from directory item number lnum[0]
405*4882a593Smuzhiyun */
406*4882a593Smuzhiyun leaf_shift_left(tb, tb->lnum[0], tb->lbytes);
407*4882a593Smuzhiyun }
408*4882a593Smuzhiyun
409*4882a593Smuzhiyun /* Calculate new position to append in item body */
410*4882a593Smuzhiyun tb->pos_in_item -= tb->lbytes;
411*4882a593Smuzhiyun }
412*4882a593Smuzhiyun
balance_leaf_paste_left_shift(struct tree_balance * tb,struct item_head * const ih,const char * const body)413*4882a593Smuzhiyun static unsigned int balance_leaf_paste_left_shift(struct tree_balance *tb,
414*4882a593Smuzhiyun struct item_head * const ih,
415*4882a593Smuzhiyun const char * const body)
416*4882a593Smuzhiyun {
417*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
418*4882a593Smuzhiyun int n = B_NR_ITEMS(tb->L[0]);
419*4882a593Smuzhiyun struct buffer_info bi;
420*4882a593Smuzhiyun int body_shift_bytes = 0;
421*4882a593Smuzhiyun
422*4882a593Smuzhiyun if (is_direntry_le_ih(item_head(tbS0, tb->item_pos))) {
423*4882a593Smuzhiyun balance_leaf_paste_left_shift_dirent(tb, ih, body);
424*4882a593Smuzhiyun return 0;
425*4882a593Smuzhiyun }
426*4882a593Smuzhiyun
427*4882a593Smuzhiyun RFALSE(tb->lbytes <= 0,
428*4882a593Smuzhiyun "PAP-12095: there is nothing to shift to L[0]. "
429*4882a593Smuzhiyun "lbytes=%d", tb->lbytes);
430*4882a593Smuzhiyun RFALSE(tb->pos_in_item != ih_item_len(item_head(tbS0, tb->item_pos)),
431*4882a593Smuzhiyun "PAP-12100: incorrect position to paste: "
432*4882a593Smuzhiyun "item_len=%d, pos_in_item=%d",
433*4882a593Smuzhiyun ih_item_len(item_head(tbS0, tb->item_pos)), tb->pos_in_item);
434*4882a593Smuzhiyun
435*4882a593Smuzhiyun /* appended item will be in L[0] in whole */
436*4882a593Smuzhiyun if (tb->lbytes >= tb->pos_in_item) {
437*4882a593Smuzhiyun struct item_head *tbS0_pos_ih, *tbL0_ih;
438*4882a593Smuzhiyun struct item_head *tbS0_0_ih;
439*4882a593Smuzhiyun struct reiserfs_key *left_delim_key;
440*4882a593Smuzhiyun int ret, l_n, version, temp_l;
441*4882a593Smuzhiyun
442*4882a593Smuzhiyun tbS0_pos_ih = item_head(tbS0, tb->item_pos);
443*4882a593Smuzhiyun tbS0_0_ih = item_head(tbS0, 0);
444*4882a593Smuzhiyun
445*4882a593Smuzhiyun /*
446*4882a593Smuzhiyun * this bytes number must be appended
447*4882a593Smuzhiyun * to the last item of L[h]
448*4882a593Smuzhiyun */
449*4882a593Smuzhiyun l_n = tb->lbytes - tb->pos_in_item;
450*4882a593Smuzhiyun
451*4882a593Smuzhiyun /* Calculate new insert_size[0] */
452*4882a593Smuzhiyun tb->insert_size[0] -= l_n;
453*4882a593Smuzhiyun
454*4882a593Smuzhiyun RFALSE(tb->insert_size[0] <= 0,
455*4882a593Smuzhiyun "PAP-12105: there is nothing to paste into "
456*4882a593Smuzhiyun "L[0]. insert_size=%d", tb->insert_size[0]);
457*4882a593Smuzhiyun
458*4882a593Smuzhiyun ret = leaf_shift_left(tb, tb->lnum[0],
459*4882a593Smuzhiyun ih_item_len(tbS0_pos_ih));
460*4882a593Smuzhiyun
461*4882a593Smuzhiyun tbL0_ih = item_head(tb->L[0], n + tb->item_pos - ret);
462*4882a593Smuzhiyun
463*4882a593Smuzhiyun /* Append to body of item in L[0] */
464*4882a593Smuzhiyun buffer_info_init_left(tb, &bi);
465*4882a593Smuzhiyun leaf_paste_in_buffer(&bi, n + tb->item_pos - ret,
466*4882a593Smuzhiyun ih_item_len(tbL0_ih), l_n, body,
467*4882a593Smuzhiyun min_t(int, l_n, tb->zeroes_num));
468*4882a593Smuzhiyun
469*4882a593Smuzhiyun /*
470*4882a593Smuzhiyun * 0-th item in S0 can be only of DIRECT type
471*4882a593Smuzhiyun * when l_n != 0
472*4882a593Smuzhiyun */
473*4882a593Smuzhiyun temp_l = l_n;
474*4882a593Smuzhiyun
475*4882a593Smuzhiyun RFALSE(ih_item_len(tbS0_0_ih),
476*4882a593Smuzhiyun "PAP-12106: item length must be 0");
477*4882a593Smuzhiyun RFALSE(comp_short_le_keys(&tbS0_0_ih->ih_key,
478*4882a593Smuzhiyun leaf_key(tb->L[0], n + tb->item_pos - ret)),
479*4882a593Smuzhiyun "PAP-12107: items must be of the same file");
480*4882a593Smuzhiyun
481*4882a593Smuzhiyun if (is_indirect_le_ih(tbL0_ih)) {
482*4882a593Smuzhiyun int shift = tb->tb_sb->s_blocksize_bits - UNFM_P_SHIFT;
483*4882a593Smuzhiyun temp_l = l_n << shift;
484*4882a593Smuzhiyun }
485*4882a593Smuzhiyun /* update key of first item in S0 */
486*4882a593Smuzhiyun version = ih_version(tbS0_0_ih);
487*4882a593Smuzhiyun add_le_key_k_offset(version, &tbS0_0_ih->ih_key, temp_l);
488*4882a593Smuzhiyun
489*4882a593Smuzhiyun /* update left delimiting key */
490*4882a593Smuzhiyun left_delim_key = internal_key(tb->CFL[0], tb->lkey[0]);
491*4882a593Smuzhiyun add_le_key_k_offset(version, left_delim_key, temp_l);
492*4882a593Smuzhiyun
493*4882a593Smuzhiyun /*
494*4882a593Smuzhiyun * Calculate new body, position in item and
495*4882a593Smuzhiyun * insert_size[0]
496*4882a593Smuzhiyun */
497*4882a593Smuzhiyun if (l_n > tb->zeroes_num) {
498*4882a593Smuzhiyun body_shift_bytes = l_n - tb->zeroes_num;
499*4882a593Smuzhiyun tb->zeroes_num = 0;
500*4882a593Smuzhiyun } else
501*4882a593Smuzhiyun tb->zeroes_num -= l_n;
502*4882a593Smuzhiyun tb->pos_in_item = 0;
503*4882a593Smuzhiyun
504*4882a593Smuzhiyun RFALSE(comp_short_le_keys(&tbS0_0_ih->ih_key,
505*4882a593Smuzhiyun leaf_key(tb->L[0],
506*4882a593Smuzhiyun B_NR_ITEMS(tb->L[0]) - 1)) ||
507*4882a593Smuzhiyun !op_is_left_mergeable(leaf_key(tbS0, 0), tbS0->b_size) ||
508*4882a593Smuzhiyun !op_is_left_mergeable(left_delim_key, tbS0->b_size),
509*4882a593Smuzhiyun "PAP-12120: item must be merge-able with left "
510*4882a593Smuzhiyun "neighboring item");
511*4882a593Smuzhiyun } else {
512*4882a593Smuzhiyun /* only part of the appended item will be in L[0] */
513*4882a593Smuzhiyun
514*4882a593Smuzhiyun /* Calculate position in item for append in S[0] */
515*4882a593Smuzhiyun tb->pos_in_item -= tb->lbytes;
516*4882a593Smuzhiyun
517*4882a593Smuzhiyun RFALSE(tb->pos_in_item <= 0,
518*4882a593Smuzhiyun "PAP-12125: no place for paste. pos_in_item=%d",
519*4882a593Smuzhiyun tb->pos_in_item);
520*4882a593Smuzhiyun
521*4882a593Smuzhiyun /*
522*4882a593Smuzhiyun * Shift lnum[0] - 1 items in whole.
523*4882a593Smuzhiyun * Shift lbytes - 1 byte from item number lnum[0]
524*4882a593Smuzhiyun */
525*4882a593Smuzhiyun leaf_shift_left(tb, tb->lnum[0], tb->lbytes);
526*4882a593Smuzhiyun }
527*4882a593Smuzhiyun return body_shift_bytes;
528*4882a593Smuzhiyun }
529*4882a593Smuzhiyun
530*4882a593Smuzhiyun
531*4882a593Smuzhiyun /* appended item will be in L[0] in whole */
balance_leaf_paste_left_whole(struct tree_balance * tb,struct item_head * const ih,const char * const body)532*4882a593Smuzhiyun static void balance_leaf_paste_left_whole(struct tree_balance *tb,
533*4882a593Smuzhiyun struct item_head * const ih,
534*4882a593Smuzhiyun const char * const body)
535*4882a593Smuzhiyun {
536*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
537*4882a593Smuzhiyun int n = B_NR_ITEMS(tb->L[0]);
538*4882a593Smuzhiyun struct buffer_info bi;
539*4882a593Smuzhiyun struct item_head *pasted;
540*4882a593Smuzhiyun int ret;
541*4882a593Smuzhiyun
542*4882a593Smuzhiyun /* if we paste into first item of S[0] and it is left mergable */
543*4882a593Smuzhiyun if (!tb->item_pos &&
544*4882a593Smuzhiyun op_is_left_mergeable(leaf_key(tbS0, 0), tbS0->b_size)) {
545*4882a593Smuzhiyun /*
546*4882a593Smuzhiyun * then increment pos_in_item by the size of the
547*4882a593Smuzhiyun * last item in L[0]
548*4882a593Smuzhiyun */
549*4882a593Smuzhiyun pasted = item_head(tb->L[0], n - 1);
550*4882a593Smuzhiyun if (is_direntry_le_ih(pasted))
551*4882a593Smuzhiyun tb->pos_in_item += ih_entry_count(pasted);
552*4882a593Smuzhiyun else
553*4882a593Smuzhiyun tb->pos_in_item += ih_item_len(pasted);
554*4882a593Smuzhiyun }
555*4882a593Smuzhiyun
556*4882a593Smuzhiyun /*
557*4882a593Smuzhiyun * Shift lnum[0] - 1 items in whole.
558*4882a593Smuzhiyun * Shift lbytes - 1 byte from item number lnum[0]
559*4882a593Smuzhiyun */
560*4882a593Smuzhiyun ret = leaf_shift_left(tb, tb->lnum[0], tb->lbytes);
561*4882a593Smuzhiyun
562*4882a593Smuzhiyun /* Append to body of item in L[0] */
563*4882a593Smuzhiyun buffer_info_init_left(tb, &bi);
564*4882a593Smuzhiyun leaf_paste_in_buffer(&bi, n + tb->item_pos - ret, tb->pos_in_item,
565*4882a593Smuzhiyun tb->insert_size[0], body, tb->zeroes_num);
566*4882a593Smuzhiyun
567*4882a593Smuzhiyun /* if appended item is directory, paste entry */
568*4882a593Smuzhiyun pasted = item_head(tb->L[0], n + tb->item_pos - ret);
569*4882a593Smuzhiyun if (is_direntry_le_ih(pasted))
570*4882a593Smuzhiyun leaf_paste_entries(&bi, n + tb->item_pos - ret,
571*4882a593Smuzhiyun tb->pos_in_item, 1,
572*4882a593Smuzhiyun (struct reiserfs_de_head *)body,
573*4882a593Smuzhiyun body + DEH_SIZE, tb->insert_size[0]);
574*4882a593Smuzhiyun
575*4882a593Smuzhiyun /*
576*4882a593Smuzhiyun * if appended item is indirect item, put unformatted node
577*4882a593Smuzhiyun * into un list
578*4882a593Smuzhiyun */
579*4882a593Smuzhiyun if (is_indirect_le_ih(pasted))
580*4882a593Smuzhiyun set_ih_free_space(pasted, 0);
581*4882a593Smuzhiyun
582*4882a593Smuzhiyun tb->insert_size[0] = 0;
583*4882a593Smuzhiyun tb->zeroes_num = 0;
584*4882a593Smuzhiyun }
585*4882a593Smuzhiyun
balance_leaf_paste_left(struct tree_balance * tb,struct item_head * const ih,const char * const body)586*4882a593Smuzhiyun static unsigned int balance_leaf_paste_left(struct tree_balance *tb,
587*4882a593Smuzhiyun struct item_head * const ih,
588*4882a593Smuzhiyun const char * const body)
589*4882a593Smuzhiyun {
590*4882a593Smuzhiyun /* we must shift the part of the appended item */
591*4882a593Smuzhiyun if (tb->item_pos == tb->lnum[0] - 1 && tb->lbytes != -1)
592*4882a593Smuzhiyun return balance_leaf_paste_left_shift(tb, ih, body);
593*4882a593Smuzhiyun else
594*4882a593Smuzhiyun balance_leaf_paste_left_whole(tb, ih, body);
595*4882a593Smuzhiyun return 0;
596*4882a593Smuzhiyun }
597*4882a593Smuzhiyun
598*4882a593Smuzhiyun /* Shift lnum[0] items from S[0] to the left neighbor L[0] */
balance_leaf_left(struct tree_balance * tb,struct item_head * const ih,const char * const body,int flag)599*4882a593Smuzhiyun static unsigned int balance_leaf_left(struct tree_balance *tb,
600*4882a593Smuzhiyun struct item_head * const ih,
601*4882a593Smuzhiyun const char * const body, int flag)
602*4882a593Smuzhiyun {
603*4882a593Smuzhiyun if (tb->lnum[0] <= 0)
604*4882a593Smuzhiyun return 0;
605*4882a593Smuzhiyun
606*4882a593Smuzhiyun /* new item or it part falls to L[0], shift it too */
607*4882a593Smuzhiyun if (tb->item_pos < tb->lnum[0]) {
608*4882a593Smuzhiyun BUG_ON(flag != M_INSERT && flag != M_PASTE);
609*4882a593Smuzhiyun
610*4882a593Smuzhiyun if (flag == M_INSERT)
611*4882a593Smuzhiyun return balance_leaf_insert_left(tb, ih, body);
612*4882a593Smuzhiyun else /* M_PASTE */
613*4882a593Smuzhiyun return balance_leaf_paste_left(tb, ih, body);
614*4882a593Smuzhiyun } else
615*4882a593Smuzhiyun /* new item doesn't fall into L[0] */
616*4882a593Smuzhiyun leaf_shift_left(tb, tb->lnum[0], tb->lbytes);
617*4882a593Smuzhiyun return 0;
618*4882a593Smuzhiyun }
619*4882a593Smuzhiyun
620*4882a593Smuzhiyun
balance_leaf_insert_right(struct tree_balance * tb,struct item_head * const ih,const char * const body)621*4882a593Smuzhiyun static void balance_leaf_insert_right(struct tree_balance *tb,
622*4882a593Smuzhiyun struct item_head * const ih,
623*4882a593Smuzhiyun const char * const body)
624*4882a593Smuzhiyun {
625*4882a593Smuzhiyun
626*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
627*4882a593Smuzhiyun int n = B_NR_ITEMS(tbS0);
628*4882a593Smuzhiyun struct buffer_info bi;
629*4882a593Smuzhiyun
630*4882a593Smuzhiyun /* new item or part of it doesn't fall into R[0] */
631*4882a593Smuzhiyun if (n - tb->rnum[0] >= tb->item_pos) {
632*4882a593Smuzhiyun leaf_shift_right(tb, tb->rnum[0], tb->rbytes);
633*4882a593Smuzhiyun return;
634*4882a593Smuzhiyun }
635*4882a593Smuzhiyun
636*4882a593Smuzhiyun /* new item or its part falls to R[0] */
637*4882a593Smuzhiyun
638*4882a593Smuzhiyun /* part of new item falls into R[0] */
639*4882a593Smuzhiyun if (tb->item_pos == n - tb->rnum[0] + 1 && tb->rbytes != -1) {
640*4882a593Smuzhiyun loff_t old_key_comp, old_len, r_zeroes_number;
641*4882a593Smuzhiyun const char *r_body;
642*4882a593Smuzhiyun int shift;
643*4882a593Smuzhiyun loff_t offset;
644*4882a593Smuzhiyun
645*4882a593Smuzhiyun leaf_shift_right(tb, tb->rnum[0] - 1, -1);
646*4882a593Smuzhiyun
647*4882a593Smuzhiyun /* Remember key component and item length */
648*4882a593Smuzhiyun old_key_comp = le_ih_k_offset(ih);
649*4882a593Smuzhiyun old_len = ih_item_len(ih);
650*4882a593Smuzhiyun
651*4882a593Smuzhiyun /*
652*4882a593Smuzhiyun * Calculate key component and item length to insert
653*4882a593Smuzhiyun * into R[0]
654*4882a593Smuzhiyun */
655*4882a593Smuzhiyun shift = 0;
656*4882a593Smuzhiyun if (is_indirect_le_ih(ih))
657*4882a593Smuzhiyun shift = tb->tb_sb->s_blocksize_bits - UNFM_P_SHIFT;
658*4882a593Smuzhiyun offset = le_ih_k_offset(ih) + ((old_len - tb->rbytes) << shift);
659*4882a593Smuzhiyun set_le_ih_k_offset(ih, offset);
660*4882a593Smuzhiyun put_ih_item_len(ih, tb->rbytes);
661*4882a593Smuzhiyun
662*4882a593Smuzhiyun /* Insert part of the item into R[0] */
663*4882a593Smuzhiyun buffer_info_init_right(tb, &bi);
664*4882a593Smuzhiyun if ((old_len - tb->rbytes) > tb->zeroes_num) {
665*4882a593Smuzhiyun r_zeroes_number = 0;
666*4882a593Smuzhiyun r_body = body + (old_len - tb->rbytes) - tb->zeroes_num;
667*4882a593Smuzhiyun } else {
668*4882a593Smuzhiyun r_body = body;
669*4882a593Smuzhiyun r_zeroes_number = tb->zeroes_num -
670*4882a593Smuzhiyun (old_len - tb->rbytes);
671*4882a593Smuzhiyun tb->zeroes_num -= r_zeroes_number;
672*4882a593Smuzhiyun }
673*4882a593Smuzhiyun
674*4882a593Smuzhiyun leaf_insert_into_buf(&bi, 0, ih, r_body, r_zeroes_number);
675*4882a593Smuzhiyun
676*4882a593Smuzhiyun /* Replace right delimiting key by first key in R[0] */
677*4882a593Smuzhiyun replace_key(tb, tb->CFR[0], tb->rkey[0], tb->R[0], 0);
678*4882a593Smuzhiyun
679*4882a593Smuzhiyun /*
680*4882a593Smuzhiyun * Calculate key component and item length to
681*4882a593Smuzhiyun * insert into S[0]
682*4882a593Smuzhiyun */
683*4882a593Smuzhiyun set_le_ih_k_offset(ih, old_key_comp);
684*4882a593Smuzhiyun put_ih_item_len(ih, old_len - tb->rbytes);
685*4882a593Smuzhiyun
686*4882a593Smuzhiyun tb->insert_size[0] -= tb->rbytes;
687*4882a593Smuzhiyun
688*4882a593Smuzhiyun } else {
689*4882a593Smuzhiyun /* whole new item falls into R[0] */
690*4882a593Smuzhiyun
691*4882a593Smuzhiyun /* Shift rnum[0]-1 items to R[0] */
692*4882a593Smuzhiyun leaf_shift_right(tb, tb->rnum[0] - 1, tb->rbytes);
693*4882a593Smuzhiyun
694*4882a593Smuzhiyun /* Insert new item into R[0] */
695*4882a593Smuzhiyun buffer_info_init_right(tb, &bi);
696*4882a593Smuzhiyun leaf_insert_into_buf(&bi, tb->item_pos - n + tb->rnum[0] - 1,
697*4882a593Smuzhiyun ih, body, tb->zeroes_num);
698*4882a593Smuzhiyun
699*4882a593Smuzhiyun if (tb->item_pos - n + tb->rnum[0] - 1 == 0)
700*4882a593Smuzhiyun replace_key(tb, tb->CFR[0], tb->rkey[0], tb->R[0], 0);
701*4882a593Smuzhiyun
702*4882a593Smuzhiyun tb->zeroes_num = tb->insert_size[0] = 0;
703*4882a593Smuzhiyun }
704*4882a593Smuzhiyun }
705*4882a593Smuzhiyun
706*4882a593Smuzhiyun
balance_leaf_paste_right_shift_dirent(struct tree_balance * tb,struct item_head * const ih,const char * const body)707*4882a593Smuzhiyun static void balance_leaf_paste_right_shift_dirent(struct tree_balance *tb,
708*4882a593Smuzhiyun struct item_head * const ih,
709*4882a593Smuzhiyun const char * const body)
710*4882a593Smuzhiyun {
711*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
712*4882a593Smuzhiyun struct buffer_info bi;
713*4882a593Smuzhiyun int entry_count;
714*4882a593Smuzhiyun
715*4882a593Smuzhiyun RFALSE(tb->zeroes_num,
716*4882a593Smuzhiyun "PAP-12145: invalid parameter in case of a directory");
717*4882a593Smuzhiyun entry_count = ih_entry_count(item_head(tbS0, tb->item_pos));
718*4882a593Smuzhiyun
719*4882a593Smuzhiyun /* new directory entry falls into R[0] */
720*4882a593Smuzhiyun if (entry_count - tb->rbytes < tb->pos_in_item) {
721*4882a593Smuzhiyun int paste_entry_position;
722*4882a593Smuzhiyun
723*4882a593Smuzhiyun RFALSE(tb->rbytes - 1 >= entry_count || !tb->insert_size[0],
724*4882a593Smuzhiyun "PAP-12150: no enough of entries to shift to R[0]: "
725*4882a593Smuzhiyun "rbytes=%d, entry_count=%d", tb->rbytes, entry_count);
726*4882a593Smuzhiyun
727*4882a593Smuzhiyun /*
728*4882a593Smuzhiyun * Shift rnum[0]-1 items in whole.
729*4882a593Smuzhiyun * Shift rbytes-1 directory entries from directory
730*4882a593Smuzhiyun * item number rnum[0]
731*4882a593Smuzhiyun */
732*4882a593Smuzhiyun leaf_shift_right(tb, tb->rnum[0], tb->rbytes - 1);
733*4882a593Smuzhiyun
734*4882a593Smuzhiyun /* Paste given directory entry to directory item */
735*4882a593Smuzhiyun paste_entry_position = tb->pos_in_item - entry_count +
736*4882a593Smuzhiyun tb->rbytes - 1;
737*4882a593Smuzhiyun buffer_info_init_right(tb, &bi);
738*4882a593Smuzhiyun leaf_paste_in_buffer(&bi, 0, paste_entry_position,
739*4882a593Smuzhiyun tb->insert_size[0], body, tb->zeroes_num);
740*4882a593Smuzhiyun
741*4882a593Smuzhiyun /* paste entry */
742*4882a593Smuzhiyun leaf_paste_entries(&bi, 0, paste_entry_position, 1,
743*4882a593Smuzhiyun (struct reiserfs_de_head *) body,
744*4882a593Smuzhiyun body + DEH_SIZE, tb->insert_size[0]);
745*4882a593Smuzhiyun
746*4882a593Smuzhiyun /* change delimiting keys */
747*4882a593Smuzhiyun if (paste_entry_position == 0)
748*4882a593Smuzhiyun replace_key(tb, tb->CFR[0], tb->rkey[0], tb->R[0], 0);
749*4882a593Smuzhiyun
750*4882a593Smuzhiyun tb->insert_size[0] = 0;
751*4882a593Smuzhiyun tb->pos_in_item++;
752*4882a593Smuzhiyun } else {
753*4882a593Smuzhiyun /* new directory entry doesn't fall into R[0] */
754*4882a593Smuzhiyun leaf_shift_right(tb, tb->rnum[0], tb->rbytes);
755*4882a593Smuzhiyun }
756*4882a593Smuzhiyun }
757*4882a593Smuzhiyun
balance_leaf_paste_right_shift(struct tree_balance * tb,struct item_head * const ih,const char * const body)758*4882a593Smuzhiyun static void balance_leaf_paste_right_shift(struct tree_balance *tb,
759*4882a593Smuzhiyun struct item_head * const ih,
760*4882a593Smuzhiyun const char * const body)
761*4882a593Smuzhiyun {
762*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
763*4882a593Smuzhiyun int n_shift, n_rem, r_zeroes_number, version;
764*4882a593Smuzhiyun unsigned long temp_rem;
765*4882a593Smuzhiyun const char *r_body;
766*4882a593Smuzhiyun struct buffer_info bi;
767*4882a593Smuzhiyun
768*4882a593Smuzhiyun /* we append to directory item */
769*4882a593Smuzhiyun if (is_direntry_le_ih(item_head(tbS0, tb->item_pos))) {
770*4882a593Smuzhiyun balance_leaf_paste_right_shift_dirent(tb, ih, body);
771*4882a593Smuzhiyun return;
772*4882a593Smuzhiyun }
773*4882a593Smuzhiyun
774*4882a593Smuzhiyun /* regular object */
775*4882a593Smuzhiyun
776*4882a593Smuzhiyun /*
777*4882a593Smuzhiyun * Calculate number of bytes which must be shifted
778*4882a593Smuzhiyun * from appended item
779*4882a593Smuzhiyun */
780*4882a593Smuzhiyun n_shift = tb->rbytes - tb->insert_size[0];
781*4882a593Smuzhiyun if (n_shift < 0)
782*4882a593Smuzhiyun n_shift = 0;
783*4882a593Smuzhiyun
784*4882a593Smuzhiyun RFALSE(tb->pos_in_item != ih_item_len(item_head(tbS0, tb->item_pos)),
785*4882a593Smuzhiyun "PAP-12155: invalid position to paste. ih_item_len=%d, "
786*4882a593Smuzhiyun "pos_in_item=%d", tb->pos_in_item,
787*4882a593Smuzhiyun ih_item_len(item_head(tbS0, tb->item_pos)));
788*4882a593Smuzhiyun
789*4882a593Smuzhiyun leaf_shift_right(tb, tb->rnum[0], n_shift);
790*4882a593Smuzhiyun
791*4882a593Smuzhiyun /*
792*4882a593Smuzhiyun * Calculate number of bytes which must remain in body
793*4882a593Smuzhiyun * after appending to R[0]
794*4882a593Smuzhiyun */
795*4882a593Smuzhiyun n_rem = tb->insert_size[0] - tb->rbytes;
796*4882a593Smuzhiyun if (n_rem < 0)
797*4882a593Smuzhiyun n_rem = 0;
798*4882a593Smuzhiyun
799*4882a593Smuzhiyun temp_rem = n_rem;
800*4882a593Smuzhiyun
801*4882a593Smuzhiyun version = ih_version(item_head(tb->R[0], 0));
802*4882a593Smuzhiyun
803*4882a593Smuzhiyun if (is_indirect_le_key(version, leaf_key(tb->R[0], 0))) {
804*4882a593Smuzhiyun int shift = tb->tb_sb->s_blocksize_bits - UNFM_P_SHIFT;
805*4882a593Smuzhiyun temp_rem = n_rem << shift;
806*4882a593Smuzhiyun }
807*4882a593Smuzhiyun
808*4882a593Smuzhiyun add_le_key_k_offset(version, leaf_key(tb->R[0], 0), temp_rem);
809*4882a593Smuzhiyun add_le_key_k_offset(version, internal_key(tb->CFR[0], tb->rkey[0]),
810*4882a593Smuzhiyun temp_rem);
811*4882a593Smuzhiyun
812*4882a593Smuzhiyun do_balance_mark_internal_dirty(tb, tb->CFR[0], 0);
813*4882a593Smuzhiyun
814*4882a593Smuzhiyun /* Append part of body into R[0] */
815*4882a593Smuzhiyun buffer_info_init_right(tb, &bi);
816*4882a593Smuzhiyun if (n_rem > tb->zeroes_num) {
817*4882a593Smuzhiyun r_zeroes_number = 0;
818*4882a593Smuzhiyun r_body = body + n_rem - tb->zeroes_num;
819*4882a593Smuzhiyun } else {
820*4882a593Smuzhiyun r_body = body;
821*4882a593Smuzhiyun r_zeroes_number = tb->zeroes_num - n_rem;
822*4882a593Smuzhiyun tb->zeroes_num -= r_zeroes_number;
823*4882a593Smuzhiyun }
824*4882a593Smuzhiyun
825*4882a593Smuzhiyun leaf_paste_in_buffer(&bi, 0, n_shift, tb->insert_size[0] - n_rem,
826*4882a593Smuzhiyun r_body, r_zeroes_number);
827*4882a593Smuzhiyun
828*4882a593Smuzhiyun if (is_indirect_le_ih(item_head(tb->R[0], 0)))
829*4882a593Smuzhiyun set_ih_free_space(item_head(tb->R[0], 0), 0);
830*4882a593Smuzhiyun
831*4882a593Smuzhiyun tb->insert_size[0] = n_rem;
832*4882a593Smuzhiyun if (!n_rem)
833*4882a593Smuzhiyun tb->pos_in_item++;
834*4882a593Smuzhiyun }
835*4882a593Smuzhiyun
balance_leaf_paste_right_whole(struct tree_balance * tb,struct item_head * const ih,const char * const body)836*4882a593Smuzhiyun static void balance_leaf_paste_right_whole(struct tree_balance *tb,
837*4882a593Smuzhiyun struct item_head * const ih,
838*4882a593Smuzhiyun const char * const body)
839*4882a593Smuzhiyun {
840*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
841*4882a593Smuzhiyun int n = B_NR_ITEMS(tbS0);
842*4882a593Smuzhiyun struct item_head *pasted;
843*4882a593Smuzhiyun struct buffer_info bi;
844*4882a593Smuzhiyun
845*4882a593Smuzhiyun buffer_info_init_right(tb, &bi);
846*4882a593Smuzhiyun leaf_shift_right(tb, tb->rnum[0], tb->rbytes);
847*4882a593Smuzhiyun
848*4882a593Smuzhiyun /* append item in R[0] */
849*4882a593Smuzhiyun if (tb->pos_in_item >= 0) {
850*4882a593Smuzhiyun buffer_info_init_right(tb, &bi);
851*4882a593Smuzhiyun leaf_paste_in_buffer(&bi, tb->item_pos - n + tb->rnum[0],
852*4882a593Smuzhiyun tb->pos_in_item, tb->insert_size[0], body,
853*4882a593Smuzhiyun tb->zeroes_num);
854*4882a593Smuzhiyun }
855*4882a593Smuzhiyun
856*4882a593Smuzhiyun /* paste new entry, if item is directory item */
857*4882a593Smuzhiyun pasted = item_head(tb->R[0], tb->item_pos - n + tb->rnum[0]);
858*4882a593Smuzhiyun if (is_direntry_le_ih(pasted) && tb->pos_in_item >= 0) {
859*4882a593Smuzhiyun leaf_paste_entries(&bi, tb->item_pos - n + tb->rnum[0],
860*4882a593Smuzhiyun tb->pos_in_item, 1,
861*4882a593Smuzhiyun (struct reiserfs_de_head *)body,
862*4882a593Smuzhiyun body + DEH_SIZE, tb->insert_size[0]);
863*4882a593Smuzhiyun
864*4882a593Smuzhiyun if (!tb->pos_in_item) {
865*4882a593Smuzhiyun
866*4882a593Smuzhiyun RFALSE(tb->item_pos - n + tb->rnum[0],
867*4882a593Smuzhiyun "PAP-12165: directory item must be first "
868*4882a593Smuzhiyun "item of node when pasting is in 0th position");
869*4882a593Smuzhiyun
870*4882a593Smuzhiyun /* update delimiting keys */
871*4882a593Smuzhiyun replace_key(tb, tb->CFR[0], tb->rkey[0], tb->R[0], 0);
872*4882a593Smuzhiyun }
873*4882a593Smuzhiyun }
874*4882a593Smuzhiyun
875*4882a593Smuzhiyun if (is_indirect_le_ih(pasted))
876*4882a593Smuzhiyun set_ih_free_space(pasted, 0);
877*4882a593Smuzhiyun tb->zeroes_num = tb->insert_size[0] = 0;
878*4882a593Smuzhiyun }
879*4882a593Smuzhiyun
balance_leaf_paste_right(struct tree_balance * tb,struct item_head * const ih,const char * const body)880*4882a593Smuzhiyun static void balance_leaf_paste_right(struct tree_balance *tb,
881*4882a593Smuzhiyun struct item_head * const ih,
882*4882a593Smuzhiyun const char * const body)
883*4882a593Smuzhiyun {
884*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
885*4882a593Smuzhiyun int n = B_NR_ITEMS(tbS0);
886*4882a593Smuzhiyun
887*4882a593Smuzhiyun /* new item doesn't fall into R[0] */
888*4882a593Smuzhiyun if (n - tb->rnum[0] > tb->item_pos) {
889*4882a593Smuzhiyun leaf_shift_right(tb, tb->rnum[0], tb->rbytes);
890*4882a593Smuzhiyun return;
891*4882a593Smuzhiyun }
892*4882a593Smuzhiyun
893*4882a593Smuzhiyun /* pasted item or part of it falls to R[0] */
894*4882a593Smuzhiyun
895*4882a593Smuzhiyun if (tb->item_pos == n - tb->rnum[0] && tb->rbytes != -1)
896*4882a593Smuzhiyun /* we must shift the part of the appended item */
897*4882a593Smuzhiyun balance_leaf_paste_right_shift(tb, ih, body);
898*4882a593Smuzhiyun else
899*4882a593Smuzhiyun /* pasted item in whole falls into R[0] */
900*4882a593Smuzhiyun balance_leaf_paste_right_whole(tb, ih, body);
901*4882a593Smuzhiyun }
902*4882a593Smuzhiyun
903*4882a593Smuzhiyun /* shift rnum[0] items from S[0] to the right neighbor R[0] */
balance_leaf_right(struct tree_balance * tb,struct item_head * const ih,const char * const body,int flag)904*4882a593Smuzhiyun static void balance_leaf_right(struct tree_balance *tb,
905*4882a593Smuzhiyun struct item_head * const ih,
906*4882a593Smuzhiyun const char * const body, int flag)
907*4882a593Smuzhiyun {
908*4882a593Smuzhiyun if (tb->rnum[0] <= 0)
909*4882a593Smuzhiyun return;
910*4882a593Smuzhiyun
911*4882a593Smuzhiyun BUG_ON(flag != M_INSERT && flag != M_PASTE);
912*4882a593Smuzhiyun
913*4882a593Smuzhiyun if (flag == M_INSERT)
914*4882a593Smuzhiyun balance_leaf_insert_right(tb, ih, body);
915*4882a593Smuzhiyun else /* M_PASTE */
916*4882a593Smuzhiyun balance_leaf_paste_right(tb, ih, body);
917*4882a593Smuzhiyun }
918*4882a593Smuzhiyun
balance_leaf_new_nodes_insert(struct tree_balance * tb,struct item_head * const ih,const char * const body,struct item_head * insert_key,struct buffer_head ** insert_ptr,int i)919*4882a593Smuzhiyun static void balance_leaf_new_nodes_insert(struct tree_balance *tb,
920*4882a593Smuzhiyun struct item_head * const ih,
921*4882a593Smuzhiyun const char * const body,
922*4882a593Smuzhiyun struct item_head *insert_key,
923*4882a593Smuzhiyun struct buffer_head **insert_ptr,
924*4882a593Smuzhiyun int i)
925*4882a593Smuzhiyun {
926*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
927*4882a593Smuzhiyun int n = B_NR_ITEMS(tbS0);
928*4882a593Smuzhiyun struct buffer_info bi;
929*4882a593Smuzhiyun int shift;
930*4882a593Smuzhiyun
931*4882a593Smuzhiyun /* new item or it part don't falls into S_new[i] */
932*4882a593Smuzhiyun if (n - tb->snum[i] >= tb->item_pos) {
933*4882a593Smuzhiyun leaf_move_items(LEAF_FROM_S_TO_SNEW, tb,
934*4882a593Smuzhiyun tb->snum[i], tb->sbytes[i], tb->S_new[i]);
935*4882a593Smuzhiyun return;
936*4882a593Smuzhiyun }
937*4882a593Smuzhiyun
938*4882a593Smuzhiyun /* new item or it's part falls to first new node S_new[i] */
939*4882a593Smuzhiyun
940*4882a593Smuzhiyun /* part of new item falls into S_new[i] */
941*4882a593Smuzhiyun if (tb->item_pos == n - tb->snum[i] + 1 && tb->sbytes[i] != -1) {
942*4882a593Smuzhiyun int old_key_comp, old_len, r_zeroes_number;
943*4882a593Smuzhiyun const char *r_body;
944*4882a593Smuzhiyun
945*4882a593Smuzhiyun /* Move snum[i]-1 items from S[0] to S_new[i] */
946*4882a593Smuzhiyun leaf_move_items(LEAF_FROM_S_TO_SNEW, tb, tb->snum[i] - 1, -1,
947*4882a593Smuzhiyun tb->S_new[i]);
948*4882a593Smuzhiyun
949*4882a593Smuzhiyun /* Remember key component and item length */
950*4882a593Smuzhiyun old_key_comp = le_ih_k_offset(ih);
951*4882a593Smuzhiyun old_len = ih_item_len(ih);
952*4882a593Smuzhiyun
953*4882a593Smuzhiyun /*
954*4882a593Smuzhiyun * Calculate key component and item length to insert
955*4882a593Smuzhiyun * into S_new[i]
956*4882a593Smuzhiyun */
957*4882a593Smuzhiyun shift = 0;
958*4882a593Smuzhiyun if (is_indirect_le_ih(ih))
959*4882a593Smuzhiyun shift = tb->tb_sb->s_blocksize_bits - UNFM_P_SHIFT;
960*4882a593Smuzhiyun set_le_ih_k_offset(ih,
961*4882a593Smuzhiyun le_ih_k_offset(ih) +
962*4882a593Smuzhiyun ((old_len - tb->sbytes[i]) << shift));
963*4882a593Smuzhiyun
964*4882a593Smuzhiyun put_ih_item_len(ih, tb->sbytes[i]);
965*4882a593Smuzhiyun
966*4882a593Smuzhiyun /* Insert part of the item into S_new[i] before 0-th item */
967*4882a593Smuzhiyun buffer_info_init_bh(tb, &bi, tb->S_new[i]);
968*4882a593Smuzhiyun
969*4882a593Smuzhiyun if ((old_len - tb->sbytes[i]) > tb->zeroes_num) {
970*4882a593Smuzhiyun r_zeroes_number = 0;
971*4882a593Smuzhiyun r_body = body + (old_len - tb->sbytes[i]) -
972*4882a593Smuzhiyun tb->zeroes_num;
973*4882a593Smuzhiyun } else {
974*4882a593Smuzhiyun r_body = body;
975*4882a593Smuzhiyun r_zeroes_number = tb->zeroes_num - (old_len -
976*4882a593Smuzhiyun tb->sbytes[i]);
977*4882a593Smuzhiyun tb->zeroes_num -= r_zeroes_number;
978*4882a593Smuzhiyun }
979*4882a593Smuzhiyun
980*4882a593Smuzhiyun leaf_insert_into_buf(&bi, 0, ih, r_body, r_zeroes_number);
981*4882a593Smuzhiyun
982*4882a593Smuzhiyun /*
983*4882a593Smuzhiyun * Calculate key component and item length to
984*4882a593Smuzhiyun * insert into S[i]
985*4882a593Smuzhiyun */
986*4882a593Smuzhiyun set_le_ih_k_offset(ih, old_key_comp);
987*4882a593Smuzhiyun put_ih_item_len(ih, old_len - tb->sbytes[i]);
988*4882a593Smuzhiyun tb->insert_size[0] -= tb->sbytes[i];
989*4882a593Smuzhiyun } else {
990*4882a593Smuzhiyun /* whole new item falls into S_new[i] */
991*4882a593Smuzhiyun
992*4882a593Smuzhiyun /*
993*4882a593Smuzhiyun * Shift snum[0] - 1 items to S_new[i]
994*4882a593Smuzhiyun * (sbytes[i] of split item)
995*4882a593Smuzhiyun */
996*4882a593Smuzhiyun leaf_move_items(LEAF_FROM_S_TO_SNEW, tb,
997*4882a593Smuzhiyun tb->snum[i] - 1, tb->sbytes[i], tb->S_new[i]);
998*4882a593Smuzhiyun
999*4882a593Smuzhiyun /* Insert new item into S_new[i] */
1000*4882a593Smuzhiyun buffer_info_init_bh(tb, &bi, tb->S_new[i]);
1001*4882a593Smuzhiyun leaf_insert_into_buf(&bi, tb->item_pos - n + tb->snum[i] - 1,
1002*4882a593Smuzhiyun ih, body, tb->zeroes_num);
1003*4882a593Smuzhiyun
1004*4882a593Smuzhiyun tb->zeroes_num = tb->insert_size[0] = 0;
1005*4882a593Smuzhiyun }
1006*4882a593Smuzhiyun }
1007*4882a593Smuzhiyun
1008*4882a593Smuzhiyun /* we append to directory item */
balance_leaf_new_nodes_paste_dirent(struct tree_balance * tb,struct item_head * const ih,const char * const body,struct item_head * insert_key,struct buffer_head ** insert_ptr,int i)1009*4882a593Smuzhiyun static void balance_leaf_new_nodes_paste_dirent(struct tree_balance *tb,
1010*4882a593Smuzhiyun struct item_head * const ih,
1011*4882a593Smuzhiyun const char * const body,
1012*4882a593Smuzhiyun struct item_head *insert_key,
1013*4882a593Smuzhiyun struct buffer_head **insert_ptr,
1014*4882a593Smuzhiyun int i)
1015*4882a593Smuzhiyun {
1016*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
1017*4882a593Smuzhiyun struct item_head *aux_ih = item_head(tbS0, tb->item_pos);
1018*4882a593Smuzhiyun int entry_count = ih_entry_count(aux_ih);
1019*4882a593Smuzhiyun struct buffer_info bi;
1020*4882a593Smuzhiyun
1021*4882a593Smuzhiyun if (entry_count - tb->sbytes[i] < tb->pos_in_item &&
1022*4882a593Smuzhiyun tb->pos_in_item <= entry_count) {
1023*4882a593Smuzhiyun /* new directory entry falls into S_new[i] */
1024*4882a593Smuzhiyun
1025*4882a593Smuzhiyun RFALSE(!tb->insert_size[0],
1026*4882a593Smuzhiyun "PAP-12215: insert_size is already 0");
1027*4882a593Smuzhiyun RFALSE(tb->sbytes[i] - 1 >= entry_count,
1028*4882a593Smuzhiyun "PAP-12220: there are no so much entries (%d), only %d",
1029*4882a593Smuzhiyun tb->sbytes[i] - 1, entry_count);
1030*4882a593Smuzhiyun
1031*4882a593Smuzhiyun /*
1032*4882a593Smuzhiyun * Shift snum[i]-1 items in whole.
1033*4882a593Smuzhiyun * Shift sbytes[i] directory entries
1034*4882a593Smuzhiyun * from directory item number snum[i]
1035*4882a593Smuzhiyun */
1036*4882a593Smuzhiyun leaf_move_items(LEAF_FROM_S_TO_SNEW, tb, tb->snum[i],
1037*4882a593Smuzhiyun tb->sbytes[i] - 1, tb->S_new[i]);
1038*4882a593Smuzhiyun
1039*4882a593Smuzhiyun /*
1040*4882a593Smuzhiyun * Paste given directory entry to
1041*4882a593Smuzhiyun * directory item
1042*4882a593Smuzhiyun */
1043*4882a593Smuzhiyun buffer_info_init_bh(tb, &bi, tb->S_new[i]);
1044*4882a593Smuzhiyun leaf_paste_in_buffer(&bi, 0, tb->pos_in_item - entry_count +
1045*4882a593Smuzhiyun tb->sbytes[i] - 1, tb->insert_size[0],
1046*4882a593Smuzhiyun body, tb->zeroes_num);
1047*4882a593Smuzhiyun
1048*4882a593Smuzhiyun /* paste new directory entry */
1049*4882a593Smuzhiyun leaf_paste_entries(&bi, 0, tb->pos_in_item - entry_count +
1050*4882a593Smuzhiyun tb->sbytes[i] - 1, 1,
1051*4882a593Smuzhiyun (struct reiserfs_de_head *) body,
1052*4882a593Smuzhiyun body + DEH_SIZE, tb->insert_size[0]);
1053*4882a593Smuzhiyun
1054*4882a593Smuzhiyun tb->insert_size[0] = 0;
1055*4882a593Smuzhiyun tb->pos_in_item++;
1056*4882a593Smuzhiyun } else {
1057*4882a593Smuzhiyun /* new directory entry doesn't fall into S_new[i] */
1058*4882a593Smuzhiyun leaf_move_items(LEAF_FROM_S_TO_SNEW, tb, tb->snum[i],
1059*4882a593Smuzhiyun tb->sbytes[i], tb->S_new[i]);
1060*4882a593Smuzhiyun }
1061*4882a593Smuzhiyun
1062*4882a593Smuzhiyun }
1063*4882a593Smuzhiyun
balance_leaf_new_nodes_paste_shift(struct tree_balance * tb,struct item_head * const ih,const char * const body,struct item_head * insert_key,struct buffer_head ** insert_ptr,int i)1064*4882a593Smuzhiyun static void balance_leaf_new_nodes_paste_shift(struct tree_balance *tb,
1065*4882a593Smuzhiyun struct item_head * const ih,
1066*4882a593Smuzhiyun const char * const body,
1067*4882a593Smuzhiyun struct item_head *insert_key,
1068*4882a593Smuzhiyun struct buffer_head **insert_ptr,
1069*4882a593Smuzhiyun int i)
1070*4882a593Smuzhiyun {
1071*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
1072*4882a593Smuzhiyun struct item_head *aux_ih = item_head(tbS0, tb->item_pos);
1073*4882a593Smuzhiyun int n_shift, n_rem, r_zeroes_number, shift;
1074*4882a593Smuzhiyun const char *r_body;
1075*4882a593Smuzhiyun struct item_head *tmp;
1076*4882a593Smuzhiyun struct buffer_info bi;
1077*4882a593Smuzhiyun
1078*4882a593Smuzhiyun RFALSE(ih, "PAP-12210: ih must be 0");
1079*4882a593Smuzhiyun
1080*4882a593Smuzhiyun if (is_direntry_le_ih(aux_ih)) {
1081*4882a593Smuzhiyun balance_leaf_new_nodes_paste_dirent(tb, ih, body, insert_key,
1082*4882a593Smuzhiyun insert_ptr, i);
1083*4882a593Smuzhiyun return;
1084*4882a593Smuzhiyun }
1085*4882a593Smuzhiyun
1086*4882a593Smuzhiyun /* regular object */
1087*4882a593Smuzhiyun
1088*4882a593Smuzhiyun
1089*4882a593Smuzhiyun RFALSE(tb->pos_in_item != ih_item_len(item_head(tbS0, tb->item_pos)) ||
1090*4882a593Smuzhiyun tb->insert_size[0] <= 0,
1091*4882a593Smuzhiyun "PAP-12225: item too short or insert_size <= 0");
1092*4882a593Smuzhiyun
1093*4882a593Smuzhiyun /*
1094*4882a593Smuzhiyun * Calculate number of bytes which must be shifted from appended item
1095*4882a593Smuzhiyun */
1096*4882a593Smuzhiyun n_shift = tb->sbytes[i] - tb->insert_size[0];
1097*4882a593Smuzhiyun if (n_shift < 0)
1098*4882a593Smuzhiyun n_shift = 0;
1099*4882a593Smuzhiyun leaf_move_items(LEAF_FROM_S_TO_SNEW, tb, tb->snum[i], n_shift,
1100*4882a593Smuzhiyun tb->S_new[i]);
1101*4882a593Smuzhiyun
1102*4882a593Smuzhiyun /*
1103*4882a593Smuzhiyun * Calculate number of bytes which must remain in body after
1104*4882a593Smuzhiyun * append to S_new[i]
1105*4882a593Smuzhiyun */
1106*4882a593Smuzhiyun n_rem = tb->insert_size[0] - tb->sbytes[i];
1107*4882a593Smuzhiyun if (n_rem < 0)
1108*4882a593Smuzhiyun n_rem = 0;
1109*4882a593Smuzhiyun
1110*4882a593Smuzhiyun /* Append part of body into S_new[0] */
1111*4882a593Smuzhiyun buffer_info_init_bh(tb, &bi, tb->S_new[i]);
1112*4882a593Smuzhiyun if (n_rem > tb->zeroes_num) {
1113*4882a593Smuzhiyun r_zeroes_number = 0;
1114*4882a593Smuzhiyun r_body = body + n_rem - tb->zeroes_num;
1115*4882a593Smuzhiyun } else {
1116*4882a593Smuzhiyun r_body = body;
1117*4882a593Smuzhiyun r_zeroes_number = tb->zeroes_num - n_rem;
1118*4882a593Smuzhiyun tb->zeroes_num -= r_zeroes_number;
1119*4882a593Smuzhiyun }
1120*4882a593Smuzhiyun
1121*4882a593Smuzhiyun leaf_paste_in_buffer(&bi, 0, n_shift, tb->insert_size[0] - n_rem,
1122*4882a593Smuzhiyun r_body, r_zeroes_number);
1123*4882a593Smuzhiyun
1124*4882a593Smuzhiyun tmp = item_head(tb->S_new[i], 0);
1125*4882a593Smuzhiyun shift = 0;
1126*4882a593Smuzhiyun if (is_indirect_le_ih(tmp)) {
1127*4882a593Smuzhiyun set_ih_free_space(tmp, 0);
1128*4882a593Smuzhiyun shift = tb->tb_sb->s_blocksize_bits - UNFM_P_SHIFT;
1129*4882a593Smuzhiyun }
1130*4882a593Smuzhiyun add_le_ih_k_offset(tmp, n_rem << shift);
1131*4882a593Smuzhiyun
1132*4882a593Smuzhiyun tb->insert_size[0] = n_rem;
1133*4882a593Smuzhiyun if (!n_rem)
1134*4882a593Smuzhiyun tb->pos_in_item++;
1135*4882a593Smuzhiyun }
1136*4882a593Smuzhiyun
balance_leaf_new_nodes_paste_whole(struct tree_balance * tb,struct item_head * const ih,const char * const body,struct item_head * insert_key,struct buffer_head ** insert_ptr,int i)1137*4882a593Smuzhiyun static void balance_leaf_new_nodes_paste_whole(struct tree_balance *tb,
1138*4882a593Smuzhiyun struct item_head * const ih,
1139*4882a593Smuzhiyun const char * const body,
1140*4882a593Smuzhiyun struct item_head *insert_key,
1141*4882a593Smuzhiyun struct buffer_head **insert_ptr,
1142*4882a593Smuzhiyun int i)
1143*4882a593Smuzhiyun
1144*4882a593Smuzhiyun {
1145*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
1146*4882a593Smuzhiyun int n = B_NR_ITEMS(tbS0);
1147*4882a593Smuzhiyun int leaf_mi;
1148*4882a593Smuzhiyun struct item_head *pasted;
1149*4882a593Smuzhiyun struct buffer_info bi;
1150*4882a593Smuzhiyun
1151*4882a593Smuzhiyun #ifdef CONFIG_REISERFS_CHECK
1152*4882a593Smuzhiyun struct item_head *ih_check = item_head(tbS0, tb->item_pos);
1153*4882a593Smuzhiyun
1154*4882a593Smuzhiyun if (!is_direntry_le_ih(ih_check) &&
1155*4882a593Smuzhiyun (tb->pos_in_item != ih_item_len(ih_check) ||
1156*4882a593Smuzhiyun tb->insert_size[0] <= 0))
1157*4882a593Smuzhiyun reiserfs_panic(tb->tb_sb,
1158*4882a593Smuzhiyun "PAP-12235",
1159*4882a593Smuzhiyun "pos_in_item must be equal to ih_item_len");
1160*4882a593Smuzhiyun #endif
1161*4882a593Smuzhiyun
1162*4882a593Smuzhiyun leaf_mi = leaf_move_items(LEAF_FROM_S_TO_SNEW, tb, tb->snum[i],
1163*4882a593Smuzhiyun tb->sbytes[i], tb->S_new[i]);
1164*4882a593Smuzhiyun
1165*4882a593Smuzhiyun RFALSE(leaf_mi,
1166*4882a593Smuzhiyun "PAP-12240: unexpected value returned by leaf_move_items (%d)",
1167*4882a593Smuzhiyun leaf_mi);
1168*4882a593Smuzhiyun
1169*4882a593Smuzhiyun /* paste into item */
1170*4882a593Smuzhiyun buffer_info_init_bh(tb, &bi, tb->S_new[i]);
1171*4882a593Smuzhiyun leaf_paste_in_buffer(&bi, tb->item_pos - n + tb->snum[i],
1172*4882a593Smuzhiyun tb->pos_in_item, tb->insert_size[0],
1173*4882a593Smuzhiyun body, tb->zeroes_num);
1174*4882a593Smuzhiyun
1175*4882a593Smuzhiyun pasted = item_head(tb->S_new[i], tb->item_pos - n +
1176*4882a593Smuzhiyun tb->snum[i]);
1177*4882a593Smuzhiyun if (is_direntry_le_ih(pasted))
1178*4882a593Smuzhiyun leaf_paste_entries(&bi, tb->item_pos - n + tb->snum[i],
1179*4882a593Smuzhiyun tb->pos_in_item, 1,
1180*4882a593Smuzhiyun (struct reiserfs_de_head *)body,
1181*4882a593Smuzhiyun body + DEH_SIZE, tb->insert_size[0]);
1182*4882a593Smuzhiyun
1183*4882a593Smuzhiyun /* if we paste to indirect item update ih_free_space */
1184*4882a593Smuzhiyun if (is_indirect_le_ih(pasted))
1185*4882a593Smuzhiyun set_ih_free_space(pasted, 0);
1186*4882a593Smuzhiyun
1187*4882a593Smuzhiyun tb->zeroes_num = tb->insert_size[0] = 0;
1188*4882a593Smuzhiyun
1189*4882a593Smuzhiyun }
balance_leaf_new_nodes_paste(struct tree_balance * tb,struct item_head * const ih,const char * const body,struct item_head * insert_key,struct buffer_head ** insert_ptr,int i)1190*4882a593Smuzhiyun static void balance_leaf_new_nodes_paste(struct tree_balance *tb,
1191*4882a593Smuzhiyun struct item_head * const ih,
1192*4882a593Smuzhiyun const char * const body,
1193*4882a593Smuzhiyun struct item_head *insert_key,
1194*4882a593Smuzhiyun struct buffer_head **insert_ptr,
1195*4882a593Smuzhiyun int i)
1196*4882a593Smuzhiyun {
1197*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
1198*4882a593Smuzhiyun int n = B_NR_ITEMS(tbS0);
1199*4882a593Smuzhiyun
1200*4882a593Smuzhiyun /* pasted item doesn't fall into S_new[i] */
1201*4882a593Smuzhiyun if (n - tb->snum[i] > tb->item_pos) {
1202*4882a593Smuzhiyun leaf_move_items(LEAF_FROM_S_TO_SNEW, tb,
1203*4882a593Smuzhiyun tb->snum[i], tb->sbytes[i], tb->S_new[i]);
1204*4882a593Smuzhiyun return;
1205*4882a593Smuzhiyun }
1206*4882a593Smuzhiyun
1207*4882a593Smuzhiyun /* pasted item or part if it falls to S_new[i] */
1208*4882a593Smuzhiyun
1209*4882a593Smuzhiyun if (tb->item_pos == n - tb->snum[i] && tb->sbytes[i] != -1)
1210*4882a593Smuzhiyun /* we must shift part of the appended item */
1211*4882a593Smuzhiyun balance_leaf_new_nodes_paste_shift(tb, ih, body, insert_key,
1212*4882a593Smuzhiyun insert_ptr, i);
1213*4882a593Smuzhiyun else
1214*4882a593Smuzhiyun /* item falls wholly into S_new[i] */
1215*4882a593Smuzhiyun balance_leaf_new_nodes_paste_whole(tb, ih, body, insert_key,
1216*4882a593Smuzhiyun insert_ptr, i);
1217*4882a593Smuzhiyun }
1218*4882a593Smuzhiyun
1219*4882a593Smuzhiyun /* Fill new nodes that appear in place of S[0] */
balance_leaf_new_nodes(struct tree_balance * tb,struct item_head * const ih,const char * const body,struct item_head * insert_key,struct buffer_head ** insert_ptr,int flag)1220*4882a593Smuzhiyun static void balance_leaf_new_nodes(struct tree_balance *tb,
1221*4882a593Smuzhiyun struct item_head * const ih,
1222*4882a593Smuzhiyun const char * const body,
1223*4882a593Smuzhiyun struct item_head *insert_key,
1224*4882a593Smuzhiyun struct buffer_head **insert_ptr,
1225*4882a593Smuzhiyun int flag)
1226*4882a593Smuzhiyun {
1227*4882a593Smuzhiyun int i;
1228*4882a593Smuzhiyun for (i = tb->blknum[0] - 2; i >= 0; i--) {
1229*4882a593Smuzhiyun BUG_ON(flag != M_INSERT && flag != M_PASTE);
1230*4882a593Smuzhiyun
1231*4882a593Smuzhiyun RFALSE(!tb->snum[i],
1232*4882a593Smuzhiyun "PAP-12200: snum[%d] == %d. Must be > 0", i,
1233*4882a593Smuzhiyun tb->snum[i]);
1234*4882a593Smuzhiyun
1235*4882a593Smuzhiyun /* here we shift from S to S_new nodes */
1236*4882a593Smuzhiyun
1237*4882a593Smuzhiyun tb->S_new[i] = get_FEB(tb);
1238*4882a593Smuzhiyun
1239*4882a593Smuzhiyun /* initialized block type and tree level */
1240*4882a593Smuzhiyun set_blkh_level(B_BLK_HEAD(tb->S_new[i]), DISK_LEAF_NODE_LEVEL);
1241*4882a593Smuzhiyun
1242*4882a593Smuzhiyun if (flag == M_INSERT)
1243*4882a593Smuzhiyun balance_leaf_new_nodes_insert(tb, ih, body, insert_key,
1244*4882a593Smuzhiyun insert_ptr, i);
1245*4882a593Smuzhiyun else /* M_PASTE */
1246*4882a593Smuzhiyun balance_leaf_new_nodes_paste(tb, ih, body, insert_key,
1247*4882a593Smuzhiyun insert_ptr, i);
1248*4882a593Smuzhiyun
1249*4882a593Smuzhiyun memcpy(insert_key + i, leaf_key(tb->S_new[i], 0), KEY_SIZE);
1250*4882a593Smuzhiyun insert_ptr[i] = tb->S_new[i];
1251*4882a593Smuzhiyun
1252*4882a593Smuzhiyun RFALSE(!buffer_journaled(tb->S_new[i])
1253*4882a593Smuzhiyun || buffer_journal_dirty(tb->S_new[i])
1254*4882a593Smuzhiyun || buffer_dirty(tb->S_new[i]),
1255*4882a593Smuzhiyun "PAP-12247: S_new[%d] : (%b)",
1256*4882a593Smuzhiyun i, tb->S_new[i]);
1257*4882a593Smuzhiyun }
1258*4882a593Smuzhiyun }
1259*4882a593Smuzhiyun
balance_leaf_finish_node_insert(struct tree_balance * tb,struct item_head * const ih,const char * const body)1260*4882a593Smuzhiyun static void balance_leaf_finish_node_insert(struct tree_balance *tb,
1261*4882a593Smuzhiyun struct item_head * const ih,
1262*4882a593Smuzhiyun const char * const body)
1263*4882a593Smuzhiyun {
1264*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
1265*4882a593Smuzhiyun struct buffer_info bi;
1266*4882a593Smuzhiyun buffer_info_init_tbS0(tb, &bi);
1267*4882a593Smuzhiyun leaf_insert_into_buf(&bi, tb->item_pos, ih, body, tb->zeroes_num);
1268*4882a593Smuzhiyun
1269*4882a593Smuzhiyun /* If we insert the first key change the delimiting key */
1270*4882a593Smuzhiyun if (tb->item_pos == 0) {
1271*4882a593Smuzhiyun if (tb->CFL[0]) /* can be 0 in reiserfsck */
1272*4882a593Smuzhiyun replace_key(tb, tb->CFL[0], tb->lkey[0], tbS0, 0);
1273*4882a593Smuzhiyun
1274*4882a593Smuzhiyun }
1275*4882a593Smuzhiyun }
1276*4882a593Smuzhiyun
balance_leaf_finish_node_paste_dirent(struct tree_balance * tb,struct item_head * const ih,const char * const body)1277*4882a593Smuzhiyun static void balance_leaf_finish_node_paste_dirent(struct tree_balance *tb,
1278*4882a593Smuzhiyun struct item_head * const ih,
1279*4882a593Smuzhiyun const char * const body)
1280*4882a593Smuzhiyun {
1281*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
1282*4882a593Smuzhiyun struct item_head *pasted = item_head(tbS0, tb->item_pos);
1283*4882a593Smuzhiyun struct buffer_info bi;
1284*4882a593Smuzhiyun
1285*4882a593Smuzhiyun if (tb->pos_in_item >= 0 && tb->pos_in_item <= ih_entry_count(pasted)) {
1286*4882a593Smuzhiyun RFALSE(!tb->insert_size[0],
1287*4882a593Smuzhiyun "PAP-12260: insert_size is 0 already");
1288*4882a593Smuzhiyun
1289*4882a593Smuzhiyun /* prepare space */
1290*4882a593Smuzhiyun buffer_info_init_tbS0(tb, &bi);
1291*4882a593Smuzhiyun leaf_paste_in_buffer(&bi, tb->item_pos, tb->pos_in_item,
1292*4882a593Smuzhiyun tb->insert_size[0], body, tb->zeroes_num);
1293*4882a593Smuzhiyun
1294*4882a593Smuzhiyun /* paste entry */
1295*4882a593Smuzhiyun leaf_paste_entries(&bi, tb->item_pos, tb->pos_in_item, 1,
1296*4882a593Smuzhiyun (struct reiserfs_de_head *)body,
1297*4882a593Smuzhiyun body + DEH_SIZE, tb->insert_size[0]);
1298*4882a593Smuzhiyun
1299*4882a593Smuzhiyun if (!tb->item_pos && !tb->pos_in_item) {
1300*4882a593Smuzhiyun RFALSE(!tb->CFL[0] || !tb->L[0],
1301*4882a593Smuzhiyun "PAP-12270: CFL[0]/L[0] must be specified");
1302*4882a593Smuzhiyun if (tb->CFL[0])
1303*4882a593Smuzhiyun replace_key(tb, tb->CFL[0], tb->lkey[0],
1304*4882a593Smuzhiyun tbS0, 0);
1305*4882a593Smuzhiyun }
1306*4882a593Smuzhiyun
1307*4882a593Smuzhiyun tb->insert_size[0] = 0;
1308*4882a593Smuzhiyun }
1309*4882a593Smuzhiyun }
1310*4882a593Smuzhiyun
balance_leaf_finish_node_paste(struct tree_balance * tb,struct item_head * const ih,const char * const body)1311*4882a593Smuzhiyun static void balance_leaf_finish_node_paste(struct tree_balance *tb,
1312*4882a593Smuzhiyun struct item_head * const ih,
1313*4882a593Smuzhiyun const char * const body)
1314*4882a593Smuzhiyun {
1315*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
1316*4882a593Smuzhiyun struct buffer_info bi;
1317*4882a593Smuzhiyun struct item_head *pasted = item_head(tbS0, tb->item_pos);
1318*4882a593Smuzhiyun
1319*4882a593Smuzhiyun /* when directory, may be new entry already pasted */
1320*4882a593Smuzhiyun if (is_direntry_le_ih(pasted)) {
1321*4882a593Smuzhiyun balance_leaf_finish_node_paste_dirent(tb, ih, body);
1322*4882a593Smuzhiyun return;
1323*4882a593Smuzhiyun }
1324*4882a593Smuzhiyun
1325*4882a593Smuzhiyun /* regular object */
1326*4882a593Smuzhiyun
1327*4882a593Smuzhiyun if (tb->pos_in_item == ih_item_len(pasted)) {
1328*4882a593Smuzhiyun RFALSE(tb->insert_size[0] <= 0,
1329*4882a593Smuzhiyun "PAP-12275: insert size must not be %d",
1330*4882a593Smuzhiyun tb->insert_size[0]);
1331*4882a593Smuzhiyun buffer_info_init_tbS0(tb, &bi);
1332*4882a593Smuzhiyun leaf_paste_in_buffer(&bi, tb->item_pos,
1333*4882a593Smuzhiyun tb->pos_in_item, tb->insert_size[0], body,
1334*4882a593Smuzhiyun tb->zeroes_num);
1335*4882a593Smuzhiyun
1336*4882a593Smuzhiyun if (is_indirect_le_ih(pasted))
1337*4882a593Smuzhiyun set_ih_free_space(pasted, 0);
1338*4882a593Smuzhiyun
1339*4882a593Smuzhiyun tb->insert_size[0] = 0;
1340*4882a593Smuzhiyun }
1341*4882a593Smuzhiyun #ifdef CONFIG_REISERFS_CHECK
1342*4882a593Smuzhiyun else if (tb->insert_size[0]) {
1343*4882a593Smuzhiyun print_cur_tb("12285");
1344*4882a593Smuzhiyun reiserfs_panic(tb->tb_sb, "PAP-12285",
1345*4882a593Smuzhiyun "insert_size must be 0 (%d)", tb->insert_size[0]);
1346*4882a593Smuzhiyun }
1347*4882a593Smuzhiyun #endif
1348*4882a593Smuzhiyun }
1349*4882a593Smuzhiyun
1350*4882a593Smuzhiyun /*
1351*4882a593Smuzhiyun * if the affected item was not wholly shifted then we
1352*4882a593Smuzhiyun * perform all necessary operations on that part or whole
1353*4882a593Smuzhiyun * of the affected item which remains in S
1354*4882a593Smuzhiyun */
balance_leaf_finish_node(struct tree_balance * tb,struct item_head * const ih,const char * const body,int flag)1355*4882a593Smuzhiyun static void balance_leaf_finish_node(struct tree_balance *tb,
1356*4882a593Smuzhiyun struct item_head * const ih,
1357*4882a593Smuzhiyun const char * const body, int flag)
1358*4882a593Smuzhiyun {
1359*4882a593Smuzhiyun /* if we must insert or append into buffer S[0] */
1360*4882a593Smuzhiyun if (0 <= tb->item_pos && tb->item_pos < tb->s0num) {
1361*4882a593Smuzhiyun if (flag == M_INSERT)
1362*4882a593Smuzhiyun balance_leaf_finish_node_insert(tb, ih, body);
1363*4882a593Smuzhiyun else /* M_PASTE */
1364*4882a593Smuzhiyun balance_leaf_finish_node_paste(tb, ih, body);
1365*4882a593Smuzhiyun }
1366*4882a593Smuzhiyun }
1367*4882a593Smuzhiyun
1368*4882a593Smuzhiyun /**
1369*4882a593Smuzhiyun * balance_leaf - reiserfs tree balancing algorithm
1370*4882a593Smuzhiyun * @tb: tree balance state
1371*4882a593Smuzhiyun * @ih: item header of inserted item (little endian)
1372*4882a593Smuzhiyun * @body: body of inserted item or bytes to paste
1373*4882a593Smuzhiyun * @flag: i - insert, d - delete, c - cut, p - paste (see do_balance)
1374*4882a593Smuzhiyun * passed back:
1375*4882a593Smuzhiyun * @insert_key: key to insert new nodes
1376*4882a593Smuzhiyun * @insert_ptr: array of nodes to insert at the next level
1377*4882a593Smuzhiyun *
1378*4882a593Smuzhiyun * In our processing of one level we sometimes determine what must be
1379*4882a593Smuzhiyun * inserted into the next higher level. This insertion consists of a
1380*4882a593Smuzhiyun * key or two keys and their corresponding pointers.
1381*4882a593Smuzhiyun */
balance_leaf(struct tree_balance * tb,struct item_head * ih,const char * body,int flag,struct item_head * insert_key,struct buffer_head ** insert_ptr)1382*4882a593Smuzhiyun static int balance_leaf(struct tree_balance *tb, struct item_head *ih,
1383*4882a593Smuzhiyun const char *body, int flag,
1384*4882a593Smuzhiyun struct item_head *insert_key,
1385*4882a593Smuzhiyun struct buffer_head **insert_ptr)
1386*4882a593Smuzhiyun {
1387*4882a593Smuzhiyun struct buffer_head *tbS0 = PATH_PLAST_BUFFER(tb->tb_path);
1388*4882a593Smuzhiyun
1389*4882a593Smuzhiyun PROC_INFO_INC(tb->tb_sb, balance_at[0]);
1390*4882a593Smuzhiyun
1391*4882a593Smuzhiyun /* Make balance in case insert_size[0] < 0 */
1392*4882a593Smuzhiyun if (tb->insert_size[0] < 0)
1393*4882a593Smuzhiyun return balance_leaf_when_delete(tb, flag);
1394*4882a593Smuzhiyun
1395*4882a593Smuzhiyun tb->item_pos = PATH_LAST_POSITION(tb->tb_path),
1396*4882a593Smuzhiyun tb->pos_in_item = tb->tb_path->pos_in_item,
1397*4882a593Smuzhiyun tb->zeroes_num = 0;
1398*4882a593Smuzhiyun if (flag == M_INSERT && !body)
1399*4882a593Smuzhiyun tb->zeroes_num = ih_item_len(ih);
1400*4882a593Smuzhiyun
1401*4882a593Smuzhiyun /*
1402*4882a593Smuzhiyun * for indirect item pos_in_item is measured in unformatted node
1403*4882a593Smuzhiyun * pointers. Recalculate to bytes
1404*4882a593Smuzhiyun */
1405*4882a593Smuzhiyun if (flag != M_INSERT
1406*4882a593Smuzhiyun && is_indirect_le_ih(item_head(tbS0, tb->item_pos)))
1407*4882a593Smuzhiyun tb->pos_in_item *= UNFM_P_SIZE;
1408*4882a593Smuzhiyun
1409*4882a593Smuzhiyun body += balance_leaf_left(tb, ih, body, flag);
1410*4882a593Smuzhiyun
1411*4882a593Smuzhiyun /* tb->lnum[0] > 0 */
1412*4882a593Smuzhiyun /* Calculate new item position */
1413*4882a593Smuzhiyun tb->item_pos -= (tb->lnum[0] - ((tb->lbytes != -1) ? 1 : 0));
1414*4882a593Smuzhiyun
1415*4882a593Smuzhiyun balance_leaf_right(tb, ih, body, flag);
1416*4882a593Smuzhiyun
1417*4882a593Smuzhiyun /* tb->rnum[0] > 0 */
1418*4882a593Smuzhiyun RFALSE(tb->blknum[0] > 3,
1419*4882a593Smuzhiyun "PAP-12180: blknum can not be %d. It must be <= 3", tb->blknum[0]);
1420*4882a593Smuzhiyun RFALSE(tb->blknum[0] < 0,
1421*4882a593Smuzhiyun "PAP-12185: blknum can not be %d. It must be >= 0", tb->blknum[0]);
1422*4882a593Smuzhiyun
1423*4882a593Smuzhiyun /*
1424*4882a593Smuzhiyun * if while adding to a node we discover that it is possible to split
1425*4882a593Smuzhiyun * it in two, and merge the left part into the left neighbor and the
1426*4882a593Smuzhiyun * right part into the right neighbor, eliminating the node
1427*4882a593Smuzhiyun */
1428*4882a593Smuzhiyun if (tb->blknum[0] == 0) { /* node S[0] is empty now */
1429*4882a593Smuzhiyun
1430*4882a593Smuzhiyun RFALSE(!tb->lnum[0] || !tb->rnum[0],
1431*4882a593Smuzhiyun "PAP-12190: lnum and rnum must not be zero");
1432*4882a593Smuzhiyun /*
1433*4882a593Smuzhiyun * if insertion was done before 0-th position in R[0], right
1434*4882a593Smuzhiyun * delimiting key of the tb->L[0]'s and left delimiting key are
1435*4882a593Smuzhiyun * not set correctly
1436*4882a593Smuzhiyun */
1437*4882a593Smuzhiyun if (tb->CFL[0]) {
1438*4882a593Smuzhiyun if (!tb->CFR[0])
1439*4882a593Smuzhiyun reiserfs_panic(tb->tb_sb, "vs-12195",
1440*4882a593Smuzhiyun "CFR not initialized");
1441*4882a593Smuzhiyun copy_key(internal_key(tb->CFL[0], tb->lkey[0]),
1442*4882a593Smuzhiyun internal_key(tb->CFR[0], tb->rkey[0]));
1443*4882a593Smuzhiyun do_balance_mark_internal_dirty(tb, tb->CFL[0], 0);
1444*4882a593Smuzhiyun }
1445*4882a593Smuzhiyun
1446*4882a593Smuzhiyun reiserfs_invalidate_buffer(tb, tbS0);
1447*4882a593Smuzhiyun return 0;
1448*4882a593Smuzhiyun }
1449*4882a593Smuzhiyun
1450*4882a593Smuzhiyun balance_leaf_new_nodes(tb, ih, body, insert_key, insert_ptr, flag);
1451*4882a593Smuzhiyun
1452*4882a593Smuzhiyun balance_leaf_finish_node(tb, ih, body, flag);
1453*4882a593Smuzhiyun
1454*4882a593Smuzhiyun #ifdef CONFIG_REISERFS_CHECK
1455*4882a593Smuzhiyun if (flag == M_PASTE && tb->insert_size[0]) {
1456*4882a593Smuzhiyun print_cur_tb("12290");
1457*4882a593Smuzhiyun reiserfs_panic(tb->tb_sb,
1458*4882a593Smuzhiyun "PAP-12290", "insert_size is still not 0 (%d)",
1459*4882a593Smuzhiyun tb->insert_size[0]);
1460*4882a593Smuzhiyun }
1461*4882a593Smuzhiyun #endif
1462*4882a593Smuzhiyun
1463*4882a593Smuzhiyun /* Leaf level of the tree is balanced (end of balance_leaf) */
1464*4882a593Smuzhiyun return 0;
1465*4882a593Smuzhiyun }
1466*4882a593Smuzhiyun
1467*4882a593Smuzhiyun /* Make empty node */
make_empty_node(struct buffer_info * bi)1468*4882a593Smuzhiyun void make_empty_node(struct buffer_info *bi)
1469*4882a593Smuzhiyun {
1470*4882a593Smuzhiyun struct block_head *blkh;
1471*4882a593Smuzhiyun
1472*4882a593Smuzhiyun RFALSE(bi->bi_bh == NULL, "PAP-12295: pointer to the buffer is NULL");
1473*4882a593Smuzhiyun
1474*4882a593Smuzhiyun blkh = B_BLK_HEAD(bi->bi_bh);
1475*4882a593Smuzhiyun set_blkh_nr_item(blkh, 0);
1476*4882a593Smuzhiyun set_blkh_free_space(blkh, MAX_CHILD_SIZE(bi->bi_bh));
1477*4882a593Smuzhiyun
1478*4882a593Smuzhiyun if (bi->bi_parent)
1479*4882a593Smuzhiyun B_N_CHILD(bi->bi_parent, bi->bi_position)->dc_size = 0; /* Endian safe if 0 */
1480*4882a593Smuzhiyun }
1481*4882a593Smuzhiyun
1482*4882a593Smuzhiyun /* Get first empty buffer */
get_FEB(struct tree_balance * tb)1483*4882a593Smuzhiyun struct buffer_head *get_FEB(struct tree_balance *tb)
1484*4882a593Smuzhiyun {
1485*4882a593Smuzhiyun int i;
1486*4882a593Smuzhiyun struct buffer_info bi;
1487*4882a593Smuzhiyun
1488*4882a593Smuzhiyun for (i = 0; i < MAX_FEB_SIZE; i++)
1489*4882a593Smuzhiyun if (tb->FEB[i] != NULL)
1490*4882a593Smuzhiyun break;
1491*4882a593Smuzhiyun
1492*4882a593Smuzhiyun if (i == MAX_FEB_SIZE)
1493*4882a593Smuzhiyun reiserfs_panic(tb->tb_sb, "vs-12300", "FEB list is empty");
1494*4882a593Smuzhiyun
1495*4882a593Smuzhiyun buffer_info_init_bh(tb, &bi, tb->FEB[i]);
1496*4882a593Smuzhiyun make_empty_node(&bi);
1497*4882a593Smuzhiyun set_buffer_uptodate(tb->FEB[i]);
1498*4882a593Smuzhiyun tb->used[i] = tb->FEB[i];
1499*4882a593Smuzhiyun tb->FEB[i] = NULL;
1500*4882a593Smuzhiyun
1501*4882a593Smuzhiyun return tb->used[i];
1502*4882a593Smuzhiyun }
1503*4882a593Smuzhiyun
1504*4882a593Smuzhiyun /* This is now used because reiserfs_free_block has to be able to schedule. */
store_thrown(struct tree_balance * tb,struct buffer_head * bh)1505*4882a593Smuzhiyun static void store_thrown(struct tree_balance *tb, struct buffer_head *bh)
1506*4882a593Smuzhiyun {
1507*4882a593Smuzhiyun int i;
1508*4882a593Smuzhiyun
1509*4882a593Smuzhiyun if (buffer_dirty(bh))
1510*4882a593Smuzhiyun reiserfs_warning(tb->tb_sb, "reiserfs-12320",
1511*4882a593Smuzhiyun "called with dirty buffer");
1512*4882a593Smuzhiyun for (i = 0; i < ARRAY_SIZE(tb->thrown); i++)
1513*4882a593Smuzhiyun if (!tb->thrown[i]) {
1514*4882a593Smuzhiyun tb->thrown[i] = bh;
1515*4882a593Smuzhiyun get_bh(bh); /* free_thrown puts this */
1516*4882a593Smuzhiyun return;
1517*4882a593Smuzhiyun }
1518*4882a593Smuzhiyun reiserfs_warning(tb->tb_sb, "reiserfs-12321",
1519*4882a593Smuzhiyun "too many thrown buffers");
1520*4882a593Smuzhiyun }
1521*4882a593Smuzhiyun
free_thrown(struct tree_balance * tb)1522*4882a593Smuzhiyun static void free_thrown(struct tree_balance *tb)
1523*4882a593Smuzhiyun {
1524*4882a593Smuzhiyun int i;
1525*4882a593Smuzhiyun b_blocknr_t blocknr;
1526*4882a593Smuzhiyun for (i = 0; i < ARRAY_SIZE(tb->thrown); i++) {
1527*4882a593Smuzhiyun if (tb->thrown[i]) {
1528*4882a593Smuzhiyun blocknr = tb->thrown[i]->b_blocknr;
1529*4882a593Smuzhiyun if (buffer_dirty(tb->thrown[i]))
1530*4882a593Smuzhiyun reiserfs_warning(tb->tb_sb, "reiserfs-12322",
1531*4882a593Smuzhiyun "called with dirty buffer %d",
1532*4882a593Smuzhiyun blocknr);
1533*4882a593Smuzhiyun brelse(tb->thrown[i]); /* incremented in store_thrown */
1534*4882a593Smuzhiyun reiserfs_free_block(tb->transaction_handle, NULL,
1535*4882a593Smuzhiyun blocknr, 0);
1536*4882a593Smuzhiyun }
1537*4882a593Smuzhiyun }
1538*4882a593Smuzhiyun }
1539*4882a593Smuzhiyun
reiserfs_invalidate_buffer(struct tree_balance * tb,struct buffer_head * bh)1540*4882a593Smuzhiyun void reiserfs_invalidate_buffer(struct tree_balance *tb, struct buffer_head *bh)
1541*4882a593Smuzhiyun {
1542*4882a593Smuzhiyun struct block_head *blkh;
1543*4882a593Smuzhiyun blkh = B_BLK_HEAD(bh);
1544*4882a593Smuzhiyun set_blkh_level(blkh, FREE_LEVEL);
1545*4882a593Smuzhiyun set_blkh_nr_item(blkh, 0);
1546*4882a593Smuzhiyun
1547*4882a593Smuzhiyun clear_buffer_dirty(bh);
1548*4882a593Smuzhiyun store_thrown(tb, bh);
1549*4882a593Smuzhiyun }
1550*4882a593Smuzhiyun
1551*4882a593Smuzhiyun /* Replace n_dest'th key in buffer dest by n_src'th key of buffer src.*/
replace_key(struct tree_balance * tb,struct buffer_head * dest,int n_dest,struct buffer_head * src,int n_src)1552*4882a593Smuzhiyun void replace_key(struct tree_balance *tb, struct buffer_head *dest, int n_dest,
1553*4882a593Smuzhiyun struct buffer_head *src, int n_src)
1554*4882a593Smuzhiyun {
1555*4882a593Smuzhiyun
1556*4882a593Smuzhiyun RFALSE(dest == NULL || src == NULL,
1557*4882a593Smuzhiyun "vs-12305: source or destination buffer is 0 (src=%p, dest=%p)",
1558*4882a593Smuzhiyun src, dest);
1559*4882a593Smuzhiyun RFALSE(!B_IS_KEYS_LEVEL(dest),
1560*4882a593Smuzhiyun "vs-12310: invalid level (%z) for destination buffer. dest must be leaf",
1561*4882a593Smuzhiyun dest);
1562*4882a593Smuzhiyun RFALSE(n_dest < 0 || n_src < 0,
1563*4882a593Smuzhiyun "vs-12315: src(%d) or dest(%d) key number < 0", n_src, n_dest);
1564*4882a593Smuzhiyun RFALSE(n_dest >= B_NR_ITEMS(dest) || n_src >= B_NR_ITEMS(src),
1565*4882a593Smuzhiyun "vs-12320: src(%d(%d)) or dest(%d(%d)) key number is too big",
1566*4882a593Smuzhiyun n_src, B_NR_ITEMS(src), n_dest, B_NR_ITEMS(dest));
1567*4882a593Smuzhiyun
1568*4882a593Smuzhiyun if (B_IS_ITEMS_LEVEL(src))
1569*4882a593Smuzhiyun /* source buffer contains leaf node */
1570*4882a593Smuzhiyun memcpy(internal_key(dest, n_dest), item_head(src, n_src),
1571*4882a593Smuzhiyun KEY_SIZE);
1572*4882a593Smuzhiyun else
1573*4882a593Smuzhiyun memcpy(internal_key(dest, n_dest), internal_key(src, n_src),
1574*4882a593Smuzhiyun KEY_SIZE);
1575*4882a593Smuzhiyun
1576*4882a593Smuzhiyun do_balance_mark_internal_dirty(tb, dest, 0);
1577*4882a593Smuzhiyun }
1578*4882a593Smuzhiyun
get_left_neighbor_position(struct tree_balance * tb,int h)1579*4882a593Smuzhiyun int get_left_neighbor_position(struct tree_balance *tb, int h)
1580*4882a593Smuzhiyun {
1581*4882a593Smuzhiyun int Sh_position = PATH_H_POSITION(tb->tb_path, h + 1);
1582*4882a593Smuzhiyun
1583*4882a593Smuzhiyun RFALSE(PATH_H_PPARENT(tb->tb_path, h) == NULL || tb->FL[h] == NULL,
1584*4882a593Smuzhiyun "vs-12325: FL[%d](%p) or F[%d](%p) does not exist",
1585*4882a593Smuzhiyun h, tb->FL[h], h, PATH_H_PPARENT(tb->tb_path, h));
1586*4882a593Smuzhiyun
1587*4882a593Smuzhiyun if (Sh_position == 0)
1588*4882a593Smuzhiyun return B_NR_ITEMS(tb->FL[h]);
1589*4882a593Smuzhiyun else
1590*4882a593Smuzhiyun return Sh_position - 1;
1591*4882a593Smuzhiyun }
1592*4882a593Smuzhiyun
get_right_neighbor_position(struct tree_balance * tb,int h)1593*4882a593Smuzhiyun int get_right_neighbor_position(struct tree_balance *tb, int h)
1594*4882a593Smuzhiyun {
1595*4882a593Smuzhiyun int Sh_position = PATH_H_POSITION(tb->tb_path, h + 1);
1596*4882a593Smuzhiyun
1597*4882a593Smuzhiyun RFALSE(PATH_H_PPARENT(tb->tb_path, h) == NULL || tb->FR[h] == NULL,
1598*4882a593Smuzhiyun "vs-12330: F[%d](%p) or FR[%d](%p) does not exist",
1599*4882a593Smuzhiyun h, PATH_H_PPARENT(tb->tb_path, h), h, tb->FR[h]);
1600*4882a593Smuzhiyun
1601*4882a593Smuzhiyun if (Sh_position == B_NR_ITEMS(PATH_H_PPARENT(tb->tb_path, h)))
1602*4882a593Smuzhiyun return 0;
1603*4882a593Smuzhiyun else
1604*4882a593Smuzhiyun return Sh_position + 1;
1605*4882a593Smuzhiyun }
1606*4882a593Smuzhiyun
1607*4882a593Smuzhiyun #ifdef CONFIG_REISERFS_CHECK
1608*4882a593Smuzhiyun
1609*4882a593Smuzhiyun int is_reusable(struct super_block *s, b_blocknr_t block, int bit_value);
check_internal_node(struct super_block * s,struct buffer_head * bh,char * mes)1610*4882a593Smuzhiyun static void check_internal_node(struct super_block *s, struct buffer_head *bh,
1611*4882a593Smuzhiyun char *mes)
1612*4882a593Smuzhiyun {
1613*4882a593Smuzhiyun struct disk_child *dc;
1614*4882a593Smuzhiyun int i;
1615*4882a593Smuzhiyun
1616*4882a593Smuzhiyun RFALSE(!bh, "PAP-12336: bh == 0");
1617*4882a593Smuzhiyun
1618*4882a593Smuzhiyun if (!bh || !B_IS_IN_TREE(bh))
1619*4882a593Smuzhiyun return;
1620*4882a593Smuzhiyun
1621*4882a593Smuzhiyun RFALSE(!buffer_dirty(bh) &&
1622*4882a593Smuzhiyun !(buffer_journaled(bh) || buffer_journal_dirty(bh)),
1623*4882a593Smuzhiyun "PAP-12337: buffer (%b) must be dirty", bh);
1624*4882a593Smuzhiyun dc = B_N_CHILD(bh, 0);
1625*4882a593Smuzhiyun
1626*4882a593Smuzhiyun for (i = 0; i <= B_NR_ITEMS(bh); i++, dc++) {
1627*4882a593Smuzhiyun if (!is_reusable(s, dc_block_number(dc), 1)) {
1628*4882a593Smuzhiyun print_cur_tb(mes);
1629*4882a593Smuzhiyun reiserfs_panic(s, "PAP-12338",
1630*4882a593Smuzhiyun "invalid child pointer %y in %b",
1631*4882a593Smuzhiyun dc, bh);
1632*4882a593Smuzhiyun }
1633*4882a593Smuzhiyun }
1634*4882a593Smuzhiyun }
1635*4882a593Smuzhiyun
locked_or_not_in_tree(struct tree_balance * tb,struct buffer_head * bh,char * which)1636*4882a593Smuzhiyun static int locked_or_not_in_tree(struct tree_balance *tb,
1637*4882a593Smuzhiyun struct buffer_head *bh, char *which)
1638*4882a593Smuzhiyun {
1639*4882a593Smuzhiyun if ((!buffer_journal_prepared(bh) && buffer_locked(bh)) ||
1640*4882a593Smuzhiyun !B_IS_IN_TREE(bh)) {
1641*4882a593Smuzhiyun reiserfs_warning(tb->tb_sb, "vs-12339", "%s (%b)", which, bh);
1642*4882a593Smuzhiyun return 1;
1643*4882a593Smuzhiyun }
1644*4882a593Smuzhiyun return 0;
1645*4882a593Smuzhiyun }
1646*4882a593Smuzhiyun
check_before_balancing(struct tree_balance * tb)1647*4882a593Smuzhiyun static int check_before_balancing(struct tree_balance *tb)
1648*4882a593Smuzhiyun {
1649*4882a593Smuzhiyun int retval = 0;
1650*4882a593Smuzhiyun
1651*4882a593Smuzhiyun if (REISERFS_SB(tb->tb_sb)->cur_tb) {
1652*4882a593Smuzhiyun reiserfs_panic(tb->tb_sb, "vs-12335", "suspect that schedule "
1653*4882a593Smuzhiyun "occurred based on cur_tb not being null at "
1654*4882a593Smuzhiyun "this point in code. do_balance cannot properly "
1655*4882a593Smuzhiyun "handle concurrent tree accesses on a same "
1656*4882a593Smuzhiyun "mount point.");
1657*4882a593Smuzhiyun }
1658*4882a593Smuzhiyun
1659*4882a593Smuzhiyun /*
1660*4882a593Smuzhiyun * double check that buffers that we will modify are unlocked.
1661*4882a593Smuzhiyun * (fix_nodes should already have prepped all of these for us).
1662*4882a593Smuzhiyun */
1663*4882a593Smuzhiyun if (tb->lnum[0]) {
1664*4882a593Smuzhiyun retval |= locked_or_not_in_tree(tb, tb->L[0], "L[0]");
1665*4882a593Smuzhiyun retval |= locked_or_not_in_tree(tb, tb->FL[0], "FL[0]");
1666*4882a593Smuzhiyun retval |= locked_or_not_in_tree(tb, tb->CFL[0], "CFL[0]");
1667*4882a593Smuzhiyun check_leaf(tb->L[0]);
1668*4882a593Smuzhiyun }
1669*4882a593Smuzhiyun if (tb->rnum[0]) {
1670*4882a593Smuzhiyun retval |= locked_or_not_in_tree(tb, tb->R[0], "R[0]");
1671*4882a593Smuzhiyun retval |= locked_or_not_in_tree(tb, tb->FR[0], "FR[0]");
1672*4882a593Smuzhiyun retval |= locked_or_not_in_tree(tb, tb->CFR[0], "CFR[0]");
1673*4882a593Smuzhiyun check_leaf(tb->R[0]);
1674*4882a593Smuzhiyun }
1675*4882a593Smuzhiyun retval |= locked_or_not_in_tree(tb, PATH_PLAST_BUFFER(tb->tb_path),
1676*4882a593Smuzhiyun "S[0]");
1677*4882a593Smuzhiyun check_leaf(PATH_PLAST_BUFFER(tb->tb_path));
1678*4882a593Smuzhiyun
1679*4882a593Smuzhiyun return retval;
1680*4882a593Smuzhiyun }
1681*4882a593Smuzhiyun
check_after_balance_leaf(struct tree_balance * tb)1682*4882a593Smuzhiyun static void check_after_balance_leaf(struct tree_balance *tb)
1683*4882a593Smuzhiyun {
1684*4882a593Smuzhiyun if (tb->lnum[0]) {
1685*4882a593Smuzhiyun if (B_FREE_SPACE(tb->L[0]) !=
1686*4882a593Smuzhiyun MAX_CHILD_SIZE(tb->L[0]) -
1687*4882a593Smuzhiyun dc_size(B_N_CHILD
1688*4882a593Smuzhiyun (tb->FL[0], get_left_neighbor_position(tb, 0)))) {
1689*4882a593Smuzhiyun print_cur_tb("12221");
1690*4882a593Smuzhiyun reiserfs_panic(tb->tb_sb, "PAP-12355",
1691*4882a593Smuzhiyun "shift to left was incorrect");
1692*4882a593Smuzhiyun }
1693*4882a593Smuzhiyun }
1694*4882a593Smuzhiyun if (tb->rnum[0]) {
1695*4882a593Smuzhiyun if (B_FREE_SPACE(tb->R[0]) !=
1696*4882a593Smuzhiyun MAX_CHILD_SIZE(tb->R[0]) -
1697*4882a593Smuzhiyun dc_size(B_N_CHILD
1698*4882a593Smuzhiyun (tb->FR[0], get_right_neighbor_position(tb, 0)))) {
1699*4882a593Smuzhiyun print_cur_tb("12222");
1700*4882a593Smuzhiyun reiserfs_panic(tb->tb_sb, "PAP-12360",
1701*4882a593Smuzhiyun "shift to right was incorrect");
1702*4882a593Smuzhiyun }
1703*4882a593Smuzhiyun }
1704*4882a593Smuzhiyun if (PATH_H_PBUFFER(tb->tb_path, 1) &&
1705*4882a593Smuzhiyun (B_FREE_SPACE(PATH_H_PBUFFER(tb->tb_path, 0)) !=
1706*4882a593Smuzhiyun (MAX_CHILD_SIZE(PATH_H_PBUFFER(tb->tb_path, 0)) -
1707*4882a593Smuzhiyun dc_size(B_N_CHILD(PATH_H_PBUFFER(tb->tb_path, 1),
1708*4882a593Smuzhiyun PATH_H_POSITION(tb->tb_path, 1)))))) {
1709*4882a593Smuzhiyun int left = B_FREE_SPACE(PATH_H_PBUFFER(tb->tb_path, 0));
1710*4882a593Smuzhiyun int right = (MAX_CHILD_SIZE(PATH_H_PBUFFER(tb->tb_path, 0)) -
1711*4882a593Smuzhiyun dc_size(B_N_CHILD(PATH_H_PBUFFER(tb->tb_path, 1),
1712*4882a593Smuzhiyun PATH_H_POSITION(tb->tb_path,
1713*4882a593Smuzhiyun 1))));
1714*4882a593Smuzhiyun print_cur_tb("12223");
1715*4882a593Smuzhiyun reiserfs_warning(tb->tb_sb, "reiserfs-12363",
1716*4882a593Smuzhiyun "B_FREE_SPACE (PATH_H_PBUFFER(tb->tb_path,0)) = %d; "
1717*4882a593Smuzhiyun "MAX_CHILD_SIZE (%d) - dc_size( %y, %d ) [%d] = %d",
1718*4882a593Smuzhiyun left,
1719*4882a593Smuzhiyun MAX_CHILD_SIZE(PATH_H_PBUFFER(tb->tb_path, 0)),
1720*4882a593Smuzhiyun PATH_H_PBUFFER(tb->tb_path, 1),
1721*4882a593Smuzhiyun PATH_H_POSITION(tb->tb_path, 1),
1722*4882a593Smuzhiyun dc_size(B_N_CHILD
1723*4882a593Smuzhiyun (PATH_H_PBUFFER(tb->tb_path, 1),
1724*4882a593Smuzhiyun PATH_H_POSITION(tb->tb_path, 1))),
1725*4882a593Smuzhiyun right);
1726*4882a593Smuzhiyun reiserfs_panic(tb->tb_sb, "PAP-12365", "S is incorrect");
1727*4882a593Smuzhiyun }
1728*4882a593Smuzhiyun }
1729*4882a593Smuzhiyun
check_leaf_level(struct tree_balance * tb)1730*4882a593Smuzhiyun static void check_leaf_level(struct tree_balance *tb)
1731*4882a593Smuzhiyun {
1732*4882a593Smuzhiyun check_leaf(tb->L[0]);
1733*4882a593Smuzhiyun check_leaf(tb->R[0]);
1734*4882a593Smuzhiyun check_leaf(PATH_PLAST_BUFFER(tb->tb_path));
1735*4882a593Smuzhiyun }
1736*4882a593Smuzhiyun
check_internal_levels(struct tree_balance * tb)1737*4882a593Smuzhiyun static void check_internal_levels(struct tree_balance *tb)
1738*4882a593Smuzhiyun {
1739*4882a593Smuzhiyun int h;
1740*4882a593Smuzhiyun
1741*4882a593Smuzhiyun /* check all internal nodes */
1742*4882a593Smuzhiyun for (h = 1; tb->insert_size[h]; h++) {
1743*4882a593Smuzhiyun check_internal_node(tb->tb_sb, PATH_H_PBUFFER(tb->tb_path, h),
1744*4882a593Smuzhiyun "BAD BUFFER ON PATH");
1745*4882a593Smuzhiyun if (tb->lnum[h])
1746*4882a593Smuzhiyun check_internal_node(tb->tb_sb, tb->L[h], "BAD L");
1747*4882a593Smuzhiyun if (tb->rnum[h])
1748*4882a593Smuzhiyun check_internal_node(tb->tb_sb, tb->R[h], "BAD R");
1749*4882a593Smuzhiyun }
1750*4882a593Smuzhiyun
1751*4882a593Smuzhiyun }
1752*4882a593Smuzhiyun
1753*4882a593Smuzhiyun #endif
1754*4882a593Smuzhiyun
1755*4882a593Smuzhiyun /*
1756*4882a593Smuzhiyun * Now we have all of the buffers that must be used in balancing of
1757*4882a593Smuzhiyun * the tree. We rely on the assumption that schedule() will not occur
1758*4882a593Smuzhiyun * while do_balance works. ( Only interrupt handlers are acceptable.)
1759*4882a593Smuzhiyun * We balance the tree according to the analysis made before this,
1760*4882a593Smuzhiyun * using buffers already obtained. For SMP support it will someday be
1761*4882a593Smuzhiyun * necessary to add ordered locking of tb.
1762*4882a593Smuzhiyun */
1763*4882a593Smuzhiyun
1764*4882a593Smuzhiyun /*
1765*4882a593Smuzhiyun * Some interesting rules of balancing:
1766*4882a593Smuzhiyun * we delete a maximum of two nodes per level per balancing: we never
1767*4882a593Smuzhiyun * delete R, when we delete two of three nodes L, S, R then we move
1768*4882a593Smuzhiyun * them into R.
1769*4882a593Smuzhiyun *
1770*4882a593Smuzhiyun * we only delete L if we are deleting two nodes, if we delete only
1771*4882a593Smuzhiyun * one node we delete S
1772*4882a593Smuzhiyun *
1773*4882a593Smuzhiyun * if we shift leaves then we shift as much as we can: this is a
1774*4882a593Smuzhiyun * deliberate policy of extremism in node packing which results in
1775*4882a593Smuzhiyun * higher average utilization after repeated random balance operations
1776*4882a593Smuzhiyun * at the cost of more memory copies and more balancing as a result of
1777*4882a593Smuzhiyun * small insertions to full nodes.
1778*4882a593Smuzhiyun *
1779*4882a593Smuzhiyun * if we shift internal nodes we try to evenly balance the node
1780*4882a593Smuzhiyun * utilization, with consequent less balancing at the cost of lower
1781*4882a593Smuzhiyun * utilization.
1782*4882a593Smuzhiyun *
1783*4882a593Smuzhiyun * one could argue that the policy for directories in leaves should be
1784*4882a593Smuzhiyun * that of internal nodes, but we will wait until another day to
1785*4882a593Smuzhiyun * evaluate this.... It would be nice to someday measure and prove
1786*4882a593Smuzhiyun * these assumptions as to what is optimal....
1787*4882a593Smuzhiyun */
1788*4882a593Smuzhiyun
do_balance_starts(struct tree_balance * tb)1789*4882a593Smuzhiyun static inline void do_balance_starts(struct tree_balance *tb)
1790*4882a593Smuzhiyun {
1791*4882a593Smuzhiyun /* use print_cur_tb() to see initial state of struct tree_balance */
1792*4882a593Smuzhiyun
1793*4882a593Smuzhiyun /* store_print_tb (tb); */
1794*4882a593Smuzhiyun
1795*4882a593Smuzhiyun /* do not delete, just comment it out */
1796*4882a593Smuzhiyun /*
1797*4882a593Smuzhiyun print_tb(flag, PATH_LAST_POSITION(tb->tb_path),
1798*4882a593Smuzhiyun tb->tb_path->pos_in_item, tb, "check");
1799*4882a593Smuzhiyun */
1800*4882a593Smuzhiyun RFALSE(check_before_balancing(tb), "PAP-12340: locked buffers in TB");
1801*4882a593Smuzhiyun #ifdef CONFIG_REISERFS_CHECK
1802*4882a593Smuzhiyun REISERFS_SB(tb->tb_sb)->cur_tb = tb;
1803*4882a593Smuzhiyun #endif
1804*4882a593Smuzhiyun }
1805*4882a593Smuzhiyun
do_balance_completed(struct tree_balance * tb)1806*4882a593Smuzhiyun static inline void do_balance_completed(struct tree_balance *tb)
1807*4882a593Smuzhiyun {
1808*4882a593Smuzhiyun
1809*4882a593Smuzhiyun #ifdef CONFIG_REISERFS_CHECK
1810*4882a593Smuzhiyun check_leaf_level(tb);
1811*4882a593Smuzhiyun check_internal_levels(tb);
1812*4882a593Smuzhiyun REISERFS_SB(tb->tb_sb)->cur_tb = NULL;
1813*4882a593Smuzhiyun #endif
1814*4882a593Smuzhiyun
1815*4882a593Smuzhiyun /*
1816*4882a593Smuzhiyun * reiserfs_free_block is no longer schedule safe. So, we need to
1817*4882a593Smuzhiyun * put the buffers we want freed on the thrown list during do_balance,
1818*4882a593Smuzhiyun * and then free them now
1819*4882a593Smuzhiyun */
1820*4882a593Smuzhiyun
1821*4882a593Smuzhiyun REISERFS_SB(tb->tb_sb)->s_do_balance++;
1822*4882a593Smuzhiyun
1823*4882a593Smuzhiyun /* release all nodes hold to perform the balancing */
1824*4882a593Smuzhiyun unfix_nodes(tb);
1825*4882a593Smuzhiyun
1826*4882a593Smuzhiyun free_thrown(tb);
1827*4882a593Smuzhiyun }
1828*4882a593Smuzhiyun
1829*4882a593Smuzhiyun /*
1830*4882a593Smuzhiyun * do_balance - balance the tree
1831*4882a593Smuzhiyun *
1832*4882a593Smuzhiyun * @tb: tree_balance structure
1833*4882a593Smuzhiyun * @ih: item header of inserted item
1834*4882a593Smuzhiyun * @body: body of inserted item or bytes to paste
1835*4882a593Smuzhiyun * @flag: 'i' - insert, 'd' - delete, 'c' - cut, 'p' paste
1836*4882a593Smuzhiyun *
1837*4882a593Smuzhiyun * Cut means delete part of an item (includes removing an entry from a
1838*4882a593Smuzhiyun * directory).
1839*4882a593Smuzhiyun *
1840*4882a593Smuzhiyun * Delete means delete whole item.
1841*4882a593Smuzhiyun *
1842*4882a593Smuzhiyun * Insert means add a new item into the tree.
1843*4882a593Smuzhiyun *
1844*4882a593Smuzhiyun * Paste means to append to the end of an existing file or to
1845*4882a593Smuzhiyun * insert a directory entry.
1846*4882a593Smuzhiyun */
do_balance(struct tree_balance * tb,struct item_head * ih,const char * body,int flag)1847*4882a593Smuzhiyun void do_balance(struct tree_balance *tb, struct item_head *ih,
1848*4882a593Smuzhiyun const char *body, int flag)
1849*4882a593Smuzhiyun {
1850*4882a593Smuzhiyun int child_pos; /* position of a child node in its parent */
1851*4882a593Smuzhiyun int h; /* level of the tree being processed */
1852*4882a593Smuzhiyun
1853*4882a593Smuzhiyun /*
1854*4882a593Smuzhiyun * in our processing of one level we sometimes determine what
1855*4882a593Smuzhiyun * must be inserted into the next higher level. This insertion
1856*4882a593Smuzhiyun * consists of a key or two keys and their corresponding
1857*4882a593Smuzhiyun * pointers
1858*4882a593Smuzhiyun */
1859*4882a593Smuzhiyun struct item_head insert_key[2];
1860*4882a593Smuzhiyun
1861*4882a593Smuzhiyun /* inserted node-ptrs for the next level */
1862*4882a593Smuzhiyun struct buffer_head *insert_ptr[2];
1863*4882a593Smuzhiyun
1864*4882a593Smuzhiyun tb->tb_mode = flag;
1865*4882a593Smuzhiyun tb->need_balance_dirty = 0;
1866*4882a593Smuzhiyun
1867*4882a593Smuzhiyun if (FILESYSTEM_CHANGED_TB(tb)) {
1868*4882a593Smuzhiyun reiserfs_panic(tb->tb_sb, "clm-6000", "fs generation has "
1869*4882a593Smuzhiyun "changed");
1870*4882a593Smuzhiyun }
1871*4882a593Smuzhiyun /* if we have no real work to do */
1872*4882a593Smuzhiyun if (!tb->insert_size[0]) {
1873*4882a593Smuzhiyun reiserfs_warning(tb->tb_sb, "PAP-12350",
1874*4882a593Smuzhiyun "insert_size == 0, mode == %c", flag);
1875*4882a593Smuzhiyun unfix_nodes(tb);
1876*4882a593Smuzhiyun return;
1877*4882a593Smuzhiyun }
1878*4882a593Smuzhiyun
1879*4882a593Smuzhiyun atomic_inc(&fs_generation(tb->tb_sb));
1880*4882a593Smuzhiyun do_balance_starts(tb);
1881*4882a593Smuzhiyun
1882*4882a593Smuzhiyun /*
1883*4882a593Smuzhiyun * balance_leaf returns 0 except if combining L R and S into
1884*4882a593Smuzhiyun * one node. see balance_internal() for explanation of this
1885*4882a593Smuzhiyun * line of code.
1886*4882a593Smuzhiyun */
1887*4882a593Smuzhiyun child_pos = PATH_H_B_ITEM_ORDER(tb->tb_path, 0) +
1888*4882a593Smuzhiyun balance_leaf(tb, ih, body, flag, insert_key, insert_ptr);
1889*4882a593Smuzhiyun
1890*4882a593Smuzhiyun #ifdef CONFIG_REISERFS_CHECK
1891*4882a593Smuzhiyun check_after_balance_leaf(tb);
1892*4882a593Smuzhiyun #endif
1893*4882a593Smuzhiyun
1894*4882a593Smuzhiyun /* Balance internal level of the tree. */
1895*4882a593Smuzhiyun for (h = 1; h < MAX_HEIGHT && tb->insert_size[h]; h++)
1896*4882a593Smuzhiyun child_pos = balance_internal(tb, h, child_pos, insert_key,
1897*4882a593Smuzhiyun insert_ptr);
1898*4882a593Smuzhiyun
1899*4882a593Smuzhiyun do_balance_completed(tb);
1900*4882a593Smuzhiyun }
1901