1*4882a593Smuzhiyun // SPDX-License-Identifier: GPL-2.0-or-later
2*4882a593Smuzhiyun /*
3*4882a593Smuzhiyun * Copyright (C) International Business Machines Corp., 2000-2004
4*4882a593Smuzhiyun */
5*4882a593Smuzhiyun
6*4882a593Smuzhiyun /*
7*4882a593Smuzhiyun * jfs_dtree.c: directory B+-tree manager
8*4882a593Smuzhiyun *
9*4882a593Smuzhiyun * B+-tree with variable length key directory:
10*4882a593Smuzhiyun *
11*4882a593Smuzhiyun * each directory page is structured as an array of 32-byte
12*4882a593Smuzhiyun * directory entry slots initialized as a freelist
13*4882a593Smuzhiyun * to avoid search/compaction of free space at insertion.
14*4882a593Smuzhiyun * when an entry is inserted, a number of slots are allocated
15*4882a593Smuzhiyun * from the freelist as required to store variable length data
16*4882a593Smuzhiyun * of the entry; when the entry is deleted, slots of the entry
17*4882a593Smuzhiyun * are returned to freelist.
18*4882a593Smuzhiyun *
19*4882a593Smuzhiyun * leaf entry stores full name as key and file serial number
20*4882a593Smuzhiyun * (aka inode number) as data.
21*4882a593Smuzhiyun * internal/router entry stores sufffix compressed name
22*4882a593Smuzhiyun * as key and simple extent descriptor as data.
23*4882a593Smuzhiyun *
24*4882a593Smuzhiyun * each directory page maintains a sorted entry index table
25*4882a593Smuzhiyun * which stores the start slot index of sorted entries
26*4882a593Smuzhiyun * to allow binary search on the table.
27*4882a593Smuzhiyun *
28*4882a593Smuzhiyun * directory starts as a root/leaf page in on-disk inode
29*4882a593Smuzhiyun * inline data area.
30*4882a593Smuzhiyun * when it becomes full, it starts a leaf of a external extent
31*4882a593Smuzhiyun * of length of 1 block. each time the first leaf becomes full,
32*4882a593Smuzhiyun * it is extended rather than split (its size is doubled),
33*4882a593Smuzhiyun * until its length becoms 4 KBytes, from then the extent is split
34*4882a593Smuzhiyun * with new 4 Kbyte extent when it becomes full
35*4882a593Smuzhiyun * to reduce external fragmentation of small directories.
36*4882a593Smuzhiyun *
37*4882a593Smuzhiyun * blah, blah, blah, for linear scan of directory in pieces by
38*4882a593Smuzhiyun * readdir().
39*4882a593Smuzhiyun *
40*4882a593Smuzhiyun *
41*4882a593Smuzhiyun * case-insensitive directory file system
42*4882a593Smuzhiyun *
43*4882a593Smuzhiyun * names are stored in case-sensitive way in leaf entry.
44*4882a593Smuzhiyun * but stored, searched and compared in case-insensitive (uppercase) order
45*4882a593Smuzhiyun * (i.e., both search key and entry key are folded for search/compare):
46*4882a593Smuzhiyun * (note that case-sensitive order is BROKEN in storage, e.g.,
47*4882a593Smuzhiyun * sensitive: Ad, aB, aC, aD -> insensitive: aB, aC, aD, Ad
48*4882a593Smuzhiyun *
49*4882a593Smuzhiyun * entries which folds to the same key makes up a equivalent class
50*4882a593Smuzhiyun * whose members are stored as contiguous cluster (may cross page boundary)
51*4882a593Smuzhiyun * but whose order is arbitrary and acts as duplicate, e.g.,
52*4882a593Smuzhiyun * abc, Abc, aBc, abC)
53*4882a593Smuzhiyun *
54*4882a593Smuzhiyun * once match is found at leaf, requires scan forward/backward
55*4882a593Smuzhiyun * either for, in case-insensitive search, duplicate
56*4882a593Smuzhiyun * or for, in case-sensitive search, for exact match
57*4882a593Smuzhiyun *
58*4882a593Smuzhiyun * router entry must be created/stored in case-insensitive way
59*4882a593Smuzhiyun * in internal entry:
60*4882a593Smuzhiyun * (right most key of left page and left most key of right page
61*4882a593Smuzhiyun * are folded, and its suffix compression is propagated as router
62*4882a593Smuzhiyun * key in parent)
63*4882a593Smuzhiyun * (e.g., if split occurs <abc> and <aBd>, <ABD> trather than <aB>
64*4882a593Smuzhiyun * should be made the router key for the split)
65*4882a593Smuzhiyun *
66*4882a593Smuzhiyun * case-insensitive search:
67*4882a593Smuzhiyun *
68*4882a593Smuzhiyun * fold search key;
69*4882a593Smuzhiyun *
70*4882a593Smuzhiyun * case-insensitive search of B-tree:
71*4882a593Smuzhiyun * for internal entry, router key is already folded;
72*4882a593Smuzhiyun * for leaf entry, fold the entry key before comparison.
73*4882a593Smuzhiyun *
74*4882a593Smuzhiyun * if (leaf entry case-insensitive match found)
75*4882a593Smuzhiyun * if (next entry satisfies case-insensitive match)
76*4882a593Smuzhiyun * return EDUPLICATE;
77*4882a593Smuzhiyun * if (prev entry satisfies case-insensitive match)
78*4882a593Smuzhiyun * return EDUPLICATE;
79*4882a593Smuzhiyun * return match;
80*4882a593Smuzhiyun * else
81*4882a593Smuzhiyun * return no match;
82*4882a593Smuzhiyun *
83*4882a593Smuzhiyun * serialization:
84*4882a593Smuzhiyun * target directory inode lock is being held on entry/exit
85*4882a593Smuzhiyun * of all main directory service routines.
86*4882a593Smuzhiyun *
87*4882a593Smuzhiyun * log based recovery:
88*4882a593Smuzhiyun */
89*4882a593Smuzhiyun
90*4882a593Smuzhiyun #include <linux/fs.h>
91*4882a593Smuzhiyun #include <linux/quotaops.h>
92*4882a593Smuzhiyun #include <linux/slab.h>
93*4882a593Smuzhiyun #include "jfs_incore.h"
94*4882a593Smuzhiyun #include "jfs_superblock.h"
95*4882a593Smuzhiyun #include "jfs_filsys.h"
96*4882a593Smuzhiyun #include "jfs_metapage.h"
97*4882a593Smuzhiyun #include "jfs_dmap.h"
98*4882a593Smuzhiyun #include "jfs_unicode.h"
99*4882a593Smuzhiyun #include "jfs_debug.h"
100*4882a593Smuzhiyun
101*4882a593Smuzhiyun /* dtree split parameter */
102*4882a593Smuzhiyun struct dtsplit {
103*4882a593Smuzhiyun struct metapage *mp;
104*4882a593Smuzhiyun s16 index;
105*4882a593Smuzhiyun s16 nslot;
106*4882a593Smuzhiyun struct component_name *key;
107*4882a593Smuzhiyun ddata_t *data;
108*4882a593Smuzhiyun struct pxdlist *pxdlist;
109*4882a593Smuzhiyun };
110*4882a593Smuzhiyun
111*4882a593Smuzhiyun #define DT_PAGE(IP, MP) BT_PAGE(IP, MP, dtpage_t, i_dtroot)
112*4882a593Smuzhiyun
113*4882a593Smuzhiyun /* get page buffer for specified block address */
114*4882a593Smuzhiyun #define DT_GETPAGE(IP, BN, MP, SIZE, P, RC) \
115*4882a593Smuzhiyun do { \
116*4882a593Smuzhiyun BT_GETPAGE(IP, BN, MP, dtpage_t, SIZE, P, RC, i_dtroot); \
117*4882a593Smuzhiyun if (!(RC)) { \
118*4882a593Smuzhiyun if (((P)->header.nextindex > \
119*4882a593Smuzhiyun (((BN) == 0) ? DTROOTMAXSLOT : (P)->header.maxslot)) || \
120*4882a593Smuzhiyun ((BN) && ((P)->header.maxslot > DTPAGEMAXSLOT))) { \
121*4882a593Smuzhiyun BT_PUTPAGE(MP); \
122*4882a593Smuzhiyun jfs_error((IP)->i_sb, \
123*4882a593Smuzhiyun "DT_GETPAGE: dtree page corrupt\n"); \
124*4882a593Smuzhiyun MP = NULL; \
125*4882a593Smuzhiyun RC = -EIO; \
126*4882a593Smuzhiyun } \
127*4882a593Smuzhiyun } \
128*4882a593Smuzhiyun } while (0)
129*4882a593Smuzhiyun
130*4882a593Smuzhiyun /* for consistency */
131*4882a593Smuzhiyun #define DT_PUTPAGE(MP) BT_PUTPAGE(MP)
132*4882a593Smuzhiyun
133*4882a593Smuzhiyun #define DT_GETSEARCH(IP, LEAF, BN, MP, P, INDEX) \
134*4882a593Smuzhiyun BT_GETSEARCH(IP, LEAF, BN, MP, dtpage_t, P, INDEX, i_dtroot)
135*4882a593Smuzhiyun
136*4882a593Smuzhiyun /*
137*4882a593Smuzhiyun * forward references
138*4882a593Smuzhiyun */
139*4882a593Smuzhiyun static int dtSplitUp(tid_t tid, struct inode *ip,
140*4882a593Smuzhiyun struct dtsplit * split, struct btstack * btstack);
141*4882a593Smuzhiyun
142*4882a593Smuzhiyun static int dtSplitPage(tid_t tid, struct inode *ip, struct dtsplit * split,
143*4882a593Smuzhiyun struct metapage ** rmpp, dtpage_t ** rpp, pxd_t * rxdp);
144*4882a593Smuzhiyun
145*4882a593Smuzhiyun static int dtExtendPage(tid_t tid, struct inode *ip,
146*4882a593Smuzhiyun struct dtsplit * split, struct btstack * btstack);
147*4882a593Smuzhiyun
148*4882a593Smuzhiyun static int dtSplitRoot(tid_t tid, struct inode *ip,
149*4882a593Smuzhiyun struct dtsplit * split, struct metapage ** rmpp);
150*4882a593Smuzhiyun
151*4882a593Smuzhiyun static int dtDeleteUp(tid_t tid, struct inode *ip, struct metapage * fmp,
152*4882a593Smuzhiyun dtpage_t * fp, struct btstack * btstack);
153*4882a593Smuzhiyun
154*4882a593Smuzhiyun static int dtRelink(tid_t tid, struct inode *ip, dtpage_t * p);
155*4882a593Smuzhiyun
156*4882a593Smuzhiyun static int dtReadFirst(struct inode *ip, struct btstack * btstack);
157*4882a593Smuzhiyun
158*4882a593Smuzhiyun static int dtReadNext(struct inode *ip,
159*4882a593Smuzhiyun loff_t * offset, struct btstack * btstack);
160*4882a593Smuzhiyun
161*4882a593Smuzhiyun static int dtCompare(struct component_name * key, dtpage_t * p, int si);
162*4882a593Smuzhiyun
163*4882a593Smuzhiyun static int ciCompare(struct component_name * key, dtpage_t * p, int si,
164*4882a593Smuzhiyun int flag);
165*4882a593Smuzhiyun
166*4882a593Smuzhiyun static void dtGetKey(dtpage_t * p, int i, struct component_name * key,
167*4882a593Smuzhiyun int flag);
168*4882a593Smuzhiyun
169*4882a593Smuzhiyun static int ciGetLeafPrefixKey(dtpage_t * lp, int li, dtpage_t * rp,
170*4882a593Smuzhiyun int ri, struct component_name * key, int flag);
171*4882a593Smuzhiyun
172*4882a593Smuzhiyun static void dtInsertEntry(dtpage_t * p, int index, struct component_name * key,
173*4882a593Smuzhiyun ddata_t * data, struct dt_lock **);
174*4882a593Smuzhiyun
175*4882a593Smuzhiyun static void dtMoveEntry(dtpage_t * sp, int si, dtpage_t * dp,
176*4882a593Smuzhiyun struct dt_lock ** sdtlock, struct dt_lock ** ddtlock,
177*4882a593Smuzhiyun int do_index);
178*4882a593Smuzhiyun
179*4882a593Smuzhiyun static void dtDeleteEntry(dtpage_t * p, int fi, struct dt_lock ** dtlock);
180*4882a593Smuzhiyun
181*4882a593Smuzhiyun static void dtTruncateEntry(dtpage_t * p, int ti, struct dt_lock ** dtlock);
182*4882a593Smuzhiyun
183*4882a593Smuzhiyun static void dtLinelockFreelist(dtpage_t * p, int m, struct dt_lock ** dtlock);
184*4882a593Smuzhiyun
185*4882a593Smuzhiyun #define ciToUpper(c) UniStrupr((c)->name)
186*4882a593Smuzhiyun
187*4882a593Smuzhiyun /*
188*4882a593Smuzhiyun * read_index_page()
189*4882a593Smuzhiyun *
190*4882a593Smuzhiyun * Reads a page of a directory's index table.
191*4882a593Smuzhiyun * Having metadata mapped into the directory inode's address space
192*4882a593Smuzhiyun * presents a multitude of problems. We avoid this by mapping to
193*4882a593Smuzhiyun * the absolute address space outside of the *_metapage routines
194*4882a593Smuzhiyun */
read_index_page(struct inode * inode,s64 blkno)195*4882a593Smuzhiyun static struct metapage *read_index_page(struct inode *inode, s64 blkno)
196*4882a593Smuzhiyun {
197*4882a593Smuzhiyun int rc;
198*4882a593Smuzhiyun s64 xaddr;
199*4882a593Smuzhiyun int xflag;
200*4882a593Smuzhiyun s32 xlen;
201*4882a593Smuzhiyun
202*4882a593Smuzhiyun rc = xtLookup(inode, blkno, 1, &xflag, &xaddr, &xlen, 1);
203*4882a593Smuzhiyun if (rc || (xaddr == 0))
204*4882a593Smuzhiyun return NULL;
205*4882a593Smuzhiyun
206*4882a593Smuzhiyun return read_metapage(inode, xaddr, PSIZE, 1);
207*4882a593Smuzhiyun }
208*4882a593Smuzhiyun
209*4882a593Smuzhiyun /*
210*4882a593Smuzhiyun * get_index_page()
211*4882a593Smuzhiyun *
212*4882a593Smuzhiyun * Same as get_index_page(), but get's a new page without reading
213*4882a593Smuzhiyun */
get_index_page(struct inode * inode,s64 blkno)214*4882a593Smuzhiyun static struct metapage *get_index_page(struct inode *inode, s64 blkno)
215*4882a593Smuzhiyun {
216*4882a593Smuzhiyun int rc;
217*4882a593Smuzhiyun s64 xaddr;
218*4882a593Smuzhiyun int xflag;
219*4882a593Smuzhiyun s32 xlen;
220*4882a593Smuzhiyun
221*4882a593Smuzhiyun rc = xtLookup(inode, blkno, 1, &xflag, &xaddr, &xlen, 1);
222*4882a593Smuzhiyun if (rc || (xaddr == 0))
223*4882a593Smuzhiyun return NULL;
224*4882a593Smuzhiyun
225*4882a593Smuzhiyun return get_metapage(inode, xaddr, PSIZE, 1);
226*4882a593Smuzhiyun }
227*4882a593Smuzhiyun
228*4882a593Smuzhiyun /*
229*4882a593Smuzhiyun * find_index()
230*4882a593Smuzhiyun *
231*4882a593Smuzhiyun * Returns dtree page containing directory table entry for specified
232*4882a593Smuzhiyun * index and pointer to its entry.
233*4882a593Smuzhiyun *
234*4882a593Smuzhiyun * mp must be released by caller.
235*4882a593Smuzhiyun */
find_index(struct inode * ip,u32 index,struct metapage ** mp,s64 * lblock)236*4882a593Smuzhiyun static struct dir_table_slot *find_index(struct inode *ip, u32 index,
237*4882a593Smuzhiyun struct metapage ** mp, s64 *lblock)
238*4882a593Smuzhiyun {
239*4882a593Smuzhiyun struct jfs_inode_info *jfs_ip = JFS_IP(ip);
240*4882a593Smuzhiyun s64 blkno;
241*4882a593Smuzhiyun s64 offset;
242*4882a593Smuzhiyun int page_offset;
243*4882a593Smuzhiyun struct dir_table_slot *slot;
244*4882a593Smuzhiyun static int maxWarnings = 10;
245*4882a593Smuzhiyun
246*4882a593Smuzhiyun if (index < 2) {
247*4882a593Smuzhiyun if (maxWarnings) {
248*4882a593Smuzhiyun jfs_warn("find_entry called with index = %d", index);
249*4882a593Smuzhiyun maxWarnings--;
250*4882a593Smuzhiyun }
251*4882a593Smuzhiyun return NULL;
252*4882a593Smuzhiyun }
253*4882a593Smuzhiyun
254*4882a593Smuzhiyun if (index >= jfs_ip->next_index) {
255*4882a593Smuzhiyun jfs_warn("find_entry called with index >= next_index");
256*4882a593Smuzhiyun return NULL;
257*4882a593Smuzhiyun }
258*4882a593Smuzhiyun
259*4882a593Smuzhiyun if (jfs_dirtable_inline(ip)) {
260*4882a593Smuzhiyun /*
261*4882a593Smuzhiyun * Inline directory table
262*4882a593Smuzhiyun */
263*4882a593Smuzhiyun *mp = NULL;
264*4882a593Smuzhiyun slot = &jfs_ip->i_dirtable[index - 2];
265*4882a593Smuzhiyun } else {
266*4882a593Smuzhiyun offset = (index - 2) * sizeof(struct dir_table_slot);
267*4882a593Smuzhiyun page_offset = offset & (PSIZE - 1);
268*4882a593Smuzhiyun blkno = ((offset + 1) >> L2PSIZE) <<
269*4882a593Smuzhiyun JFS_SBI(ip->i_sb)->l2nbperpage;
270*4882a593Smuzhiyun
271*4882a593Smuzhiyun if (*mp && (*lblock != blkno)) {
272*4882a593Smuzhiyun release_metapage(*mp);
273*4882a593Smuzhiyun *mp = NULL;
274*4882a593Smuzhiyun }
275*4882a593Smuzhiyun if (!(*mp)) {
276*4882a593Smuzhiyun *lblock = blkno;
277*4882a593Smuzhiyun *mp = read_index_page(ip, blkno);
278*4882a593Smuzhiyun }
279*4882a593Smuzhiyun if (!(*mp)) {
280*4882a593Smuzhiyun jfs_err("free_index: error reading directory table");
281*4882a593Smuzhiyun return NULL;
282*4882a593Smuzhiyun }
283*4882a593Smuzhiyun
284*4882a593Smuzhiyun slot =
285*4882a593Smuzhiyun (struct dir_table_slot *) ((char *) (*mp)->data +
286*4882a593Smuzhiyun page_offset);
287*4882a593Smuzhiyun }
288*4882a593Smuzhiyun return slot;
289*4882a593Smuzhiyun }
290*4882a593Smuzhiyun
lock_index(tid_t tid,struct inode * ip,struct metapage * mp,u32 index)291*4882a593Smuzhiyun static inline void lock_index(tid_t tid, struct inode *ip, struct metapage * mp,
292*4882a593Smuzhiyun u32 index)
293*4882a593Smuzhiyun {
294*4882a593Smuzhiyun struct tlock *tlck;
295*4882a593Smuzhiyun struct linelock *llck;
296*4882a593Smuzhiyun struct lv *lv;
297*4882a593Smuzhiyun
298*4882a593Smuzhiyun tlck = txLock(tid, ip, mp, tlckDATA);
299*4882a593Smuzhiyun llck = (struct linelock *) tlck->lock;
300*4882a593Smuzhiyun
301*4882a593Smuzhiyun if (llck->index >= llck->maxcnt)
302*4882a593Smuzhiyun llck = txLinelock(llck);
303*4882a593Smuzhiyun lv = &llck->lv[llck->index];
304*4882a593Smuzhiyun
305*4882a593Smuzhiyun /*
306*4882a593Smuzhiyun * Linelock slot size is twice the size of directory table
307*4882a593Smuzhiyun * slot size. 512 entries per page.
308*4882a593Smuzhiyun */
309*4882a593Smuzhiyun lv->offset = ((index - 2) & 511) >> 1;
310*4882a593Smuzhiyun lv->length = 1;
311*4882a593Smuzhiyun llck->index++;
312*4882a593Smuzhiyun }
313*4882a593Smuzhiyun
314*4882a593Smuzhiyun /*
315*4882a593Smuzhiyun * add_index()
316*4882a593Smuzhiyun *
317*4882a593Smuzhiyun * Adds an entry to the directory index table. This is used to provide
318*4882a593Smuzhiyun * each directory entry with a persistent index in which to resume
319*4882a593Smuzhiyun * directory traversals
320*4882a593Smuzhiyun */
add_index(tid_t tid,struct inode * ip,s64 bn,int slot)321*4882a593Smuzhiyun static u32 add_index(tid_t tid, struct inode *ip, s64 bn, int slot)
322*4882a593Smuzhiyun {
323*4882a593Smuzhiyun struct super_block *sb = ip->i_sb;
324*4882a593Smuzhiyun struct jfs_sb_info *sbi = JFS_SBI(sb);
325*4882a593Smuzhiyun struct jfs_inode_info *jfs_ip = JFS_IP(ip);
326*4882a593Smuzhiyun u64 blkno;
327*4882a593Smuzhiyun struct dir_table_slot *dirtab_slot;
328*4882a593Smuzhiyun u32 index;
329*4882a593Smuzhiyun struct linelock *llck;
330*4882a593Smuzhiyun struct lv *lv;
331*4882a593Smuzhiyun struct metapage *mp;
332*4882a593Smuzhiyun s64 offset;
333*4882a593Smuzhiyun uint page_offset;
334*4882a593Smuzhiyun struct tlock *tlck;
335*4882a593Smuzhiyun s64 xaddr;
336*4882a593Smuzhiyun
337*4882a593Smuzhiyun ASSERT(DO_INDEX(ip));
338*4882a593Smuzhiyun
339*4882a593Smuzhiyun if (jfs_ip->next_index < 2) {
340*4882a593Smuzhiyun jfs_warn("add_index: next_index = %d. Resetting!",
341*4882a593Smuzhiyun jfs_ip->next_index);
342*4882a593Smuzhiyun jfs_ip->next_index = 2;
343*4882a593Smuzhiyun }
344*4882a593Smuzhiyun
345*4882a593Smuzhiyun index = jfs_ip->next_index++;
346*4882a593Smuzhiyun
347*4882a593Smuzhiyun if (index <= MAX_INLINE_DIRTABLE_ENTRY) {
348*4882a593Smuzhiyun /*
349*4882a593Smuzhiyun * i_size reflects size of index table, or 8 bytes per entry.
350*4882a593Smuzhiyun */
351*4882a593Smuzhiyun ip->i_size = (loff_t) (index - 1) << 3;
352*4882a593Smuzhiyun
353*4882a593Smuzhiyun /*
354*4882a593Smuzhiyun * dir table fits inline within inode
355*4882a593Smuzhiyun */
356*4882a593Smuzhiyun dirtab_slot = &jfs_ip->i_dirtable[index-2];
357*4882a593Smuzhiyun dirtab_slot->flag = DIR_INDEX_VALID;
358*4882a593Smuzhiyun dirtab_slot->slot = slot;
359*4882a593Smuzhiyun DTSaddress(dirtab_slot, bn);
360*4882a593Smuzhiyun
361*4882a593Smuzhiyun set_cflag(COMMIT_Dirtable, ip);
362*4882a593Smuzhiyun
363*4882a593Smuzhiyun return index;
364*4882a593Smuzhiyun }
365*4882a593Smuzhiyun if (index == (MAX_INLINE_DIRTABLE_ENTRY + 1)) {
366*4882a593Smuzhiyun struct dir_table_slot temp_table[12];
367*4882a593Smuzhiyun
368*4882a593Smuzhiyun /*
369*4882a593Smuzhiyun * It's time to move the inline table to an external
370*4882a593Smuzhiyun * page and begin to build the xtree
371*4882a593Smuzhiyun */
372*4882a593Smuzhiyun if (dquot_alloc_block(ip, sbi->nbperpage))
373*4882a593Smuzhiyun goto clean_up;
374*4882a593Smuzhiyun if (dbAlloc(ip, 0, sbi->nbperpage, &xaddr)) {
375*4882a593Smuzhiyun dquot_free_block(ip, sbi->nbperpage);
376*4882a593Smuzhiyun goto clean_up;
377*4882a593Smuzhiyun }
378*4882a593Smuzhiyun
379*4882a593Smuzhiyun /*
380*4882a593Smuzhiyun * Save the table, we're going to overwrite it with the
381*4882a593Smuzhiyun * xtree root
382*4882a593Smuzhiyun */
383*4882a593Smuzhiyun memcpy(temp_table, &jfs_ip->i_dirtable, sizeof(temp_table));
384*4882a593Smuzhiyun
385*4882a593Smuzhiyun /*
386*4882a593Smuzhiyun * Initialize empty x-tree
387*4882a593Smuzhiyun */
388*4882a593Smuzhiyun xtInitRoot(tid, ip);
389*4882a593Smuzhiyun
390*4882a593Smuzhiyun /*
391*4882a593Smuzhiyun * Add the first block to the xtree
392*4882a593Smuzhiyun */
393*4882a593Smuzhiyun if (xtInsert(tid, ip, 0, 0, sbi->nbperpage, &xaddr, 0)) {
394*4882a593Smuzhiyun /* This really shouldn't fail */
395*4882a593Smuzhiyun jfs_warn("add_index: xtInsert failed!");
396*4882a593Smuzhiyun memcpy(&jfs_ip->i_dirtable, temp_table,
397*4882a593Smuzhiyun sizeof (temp_table));
398*4882a593Smuzhiyun dbFree(ip, xaddr, sbi->nbperpage);
399*4882a593Smuzhiyun dquot_free_block(ip, sbi->nbperpage);
400*4882a593Smuzhiyun goto clean_up;
401*4882a593Smuzhiyun }
402*4882a593Smuzhiyun ip->i_size = PSIZE;
403*4882a593Smuzhiyun
404*4882a593Smuzhiyun mp = get_index_page(ip, 0);
405*4882a593Smuzhiyun if (!mp) {
406*4882a593Smuzhiyun jfs_err("add_index: get_metapage failed!");
407*4882a593Smuzhiyun xtTruncate(tid, ip, 0, COMMIT_PWMAP);
408*4882a593Smuzhiyun memcpy(&jfs_ip->i_dirtable, temp_table,
409*4882a593Smuzhiyun sizeof (temp_table));
410*4882a593Smuzhiyun goto clean_up;
411*4882a593Smuzhiyun }
412*4882a593Smuzhiyun tlck = txLock(tid, ip, mp, tlckDATA);
413*4882a593Smuzhiyun llck = (struct linelock *) & tlck->lock;
414*4882a593Smuzhiyun ASSERT(llck->index == 0);
415*4882a593Smuzhiyun lv = &llck->lv[0];
416*4882a593Smuzhiyun
417*4882a593Smuzhiyun lv->offset = 0;
418*4882a593Smuzhiyun lv->length = 6; /* tlckDATA slot size is 16 bytes */
419*4882a593Smuzhiyun llck->index++;
420*4882a593Smuzhiyun
421*4882a593Smuzhiyun memcpy(mp->data, temp_table, sizeof(temp_table));
422*4882a593Smuzhiyun
423*4882a593Smuzhiyun mark_metapage_dirty(mp);
424*4882a593Smuzhiyun release_metapage(mp);
425*4882a593Smuzhiyun
426*4882a593Smuzhiyun /*
427*4882a593Smuzhiyun * Logging is now directed by xtree tlocks
428*4882a593Smuzhiyun */
429*4882a593Smuzhiyun clear_cflag(COMMIT_Dirtable, ip);
430*4882a593Smuzhiyun }
431*4882a593Smuzhiyun
432*4882a593Smuzhiyun offset = (index - 2) * sizeof(struct dir_table_slot);
433*4882a593Smuzhiyun page_offset = offset & (PSIZE - 1);
434*4882a593Smuzhiyun blkno = ((offset + 1) >> L2PSIZE) << sbi->l2nbperpage;
435*4882a593Smuzhiyun if (page_offset == 0) {
436*4882a593Smuzhiyun /*
437*4882a593Smuzhiyun * This will be the beginning of a new page
438*4882a593Smuzhiyun */
439*4882a593Smuzhiyun xaddr = 0;
440*4882a593Smuzhiyun if (xtInsert(tid, ip, 0, blkno, sbi->nbperpage, &xaddr, 0)) {
441*4882a593Smuzhiyun jfs_warn("add_index: xtInsert failed!");
442*4882a593Smuzhiyun goto clean_up;
443*4882a593Smuzhiyun }
444*4882a593Smuzhiyun ip->i_size += PSIZE;
445*4882a593Smuzhiyun
446*4882a593Smuzhiyun if ((mp = get_index_page(ip, blkno)))
447*4882a593Smuzhiyun memset(mp->data, 0, PSIZE); /* Just looks better */
448*4882a593Smuzhiyun else
449*4882a593Smuzhiyun xtTruncate(tid, ip, offset, COMMIT_PWMAP);
450*4882a593Smuzhiyun } else
451*4882a593Smuzhiyun mp = read_index_page(ip, blkno);
452*4882a593Smuzhiyun
453*4882a593Smuzhiyun if (!mp) {
454*4882a593Smuzhiyun jfs_err("add_index: get/read_metapage failed!");
455*4882a593Smuzhiyun goto clean_up;
456*4882a593Smuzhiyun }
457*4882a593Smuzhiyun
458*4882a593Smuzhiyun lock_index(tid, ip, mp, index);
459*4882a593Smuzhiyun
460*4882a593Smuzhiyun dirtab_slot =
461*4882a593Smuzhiyun (struct dir_table_slot *) ((char *) mp->data + page_offset);
462*4882a593Smuzhiyun dirtab_slot->flag = DIR_INDEX_VALID;
463*4882a593Smuzhiyun dirtab_slot->slot = slot;
464*4882a593Smuzhiyun DTSaddress(dirtab_slot, bn);
465*4882a593Smuzhiyun
466*4882a593Smuzhiyun mark_metapage_dirty(mp);
467*4882a593Smuzhiyun release_metapage(mp);
468*4882a593Smuzhiyun
469*4882a593Smuzhiyun return index;
470*4882a593Smuzhiyun
471*4882a593Smuzhiyun clean_up:
472*4882a593Smuzhiyun
473*4882a593Smuzhiyun jfs_ip->next_index--;
474*4882a593Smuzhiyun
475*4882a593Smuzhiyun return 0;
476*4882a593Smuzhiyun }
477*4882a593Smuzhiyun
478*4882a593Smuzhiyun /*
479*4882a593Smuzhiyun * free_index()
480*4882a593Smuzhiyun *
481*4882a593Smuzhiyun * Marks an entry to the directory index table as free.
482*4882a593Smuzhiyun */
free_index(tid_t tid,struct inode * ip,u32 index,u32 next)483*4882a593Smuzhiyun static void free_index(tid_t tid, struct inode *ip, u32 index, u32 next)
484*4882a593Smuzhiyun {
485*4882a593Smuzhiyun struct dir_table_slot *dirtab_slot;
486*4882a593Smuzhiyun s64 lblock;
487*4882a593Smuzhiyun struct metapage *mp = NULL;
488*4882a593Smuzhiyun
489*4882a593Smuzhiyun dirtab_slot = find_index(ip, index, &mp, &lblock);
490*4882a593Smuzhiyun
491*4882a593Smuzhiyun if (!dirtab_slot)
492*4882a593Smuzhiyun return;
493*4882a593Smuzhiyun
494*4882a593Smuzhiyun dirtab_slot->flag = DIR_INDEX_FREE;
495*4882a593Smuzhiyun dirtab_slot->slot = dirtab_slot->addr1 = 0;
496*4882a593Smuzhiyun dirtab_slot->addr2 = cpu_to_le32(next);
497*4882a593Smuzhiyun
498*4882a593Smuzhiyun if (mp) {
499*4882a593Smuzhiyun lock_index(tid, ip, mp, index);
500*4882a593Smuzhiyun mark_metapage_dirty(mp);
501*4882a593Smuzhiyun release_metapage(mp);
502*4882a593Smuzhiyun } else
503*4882a593Smuzhiyun set_cflag(COMMIT_Dirtable, ip);
504*4882a593Smuzhiyun }
505*4882a593Smuzhiyun
506*4882a593Smuzhiyun /*
507*4882a593Smuzhiyun * modify_index()
508*4882a593Smuzhiyun *
509*4882a593Smuzhiyun * Changes an entry in the directory index table
510*4882a593Smuzhiyun */
modify_index(tid_t tid,struct inode * ip,u32 index,s64 bn,int slot,struct metapage ** mp,s64 * lblock)511*4882a593Smuzhiyun static void modify_index(tid_t tid, struct inode *ip, u32 index, s64 bn,
512*4882a593Smuzhiyun int slot, struct metapage ** mp, s64 *lblock)
513*4882a593Smuzhiyun {
514*4882a593Smuzhiyun struct dir_table_slot *dirtab_slot;
515*4882a593Smuzhiyun
516*4882a593Smuzhiyun dirtab_slot = find_index(ip, index, mp, lblock);
517*4882a593Smuzhiyun
518*4882a593Smuzhiyun if (!dirtab_slot)
519*4882a593Smuzhiyun return;
520*4882a593Smuzhiyun
521*4882a593Smuzhiyun DTSaddress(dirtab_slot, bn);
522*4882a593Smuzhiyun dirtab_slot->slot = slot;
523*4882a593Smuzhiyun
524*4882a593Smuzhiyun if (*mp) {
525*4882a593Smuzhiyun lock_index(tid, ip, *mp, index);
526*4882a593Smuzhiyun mark_metapage_dirty(*mp);
527*4882a593Smuzhiyun } else
528*4882a593Smuzhiyun set_cflag(COMMIT_Dirtable, ip);
529*4882a593Smuzhiyun }
530*4882a593Smuzhiyun
531*4882a593Smuzhiyun /*
532*4882a593Smuzhiyun * read_index()
533*4882a593Smuzhiyun *
534*4882a593Smuzhiyun * reads a directory table slot
535*4882a593Smuzhiyun */
read_index(struct inode * ip,u32 index,struct dir_table_slot * dirtab_slot)536*4882a593Smuzhiyun static int read_index(struct inode *ip, u32 index,
537*4882a593Smuzhiyun struct dir_table_slot * dirtab_slot)
538*4882a593Smuzhiyun {
539*4882a593Smuzhiyun s64 lblock;
540*4882a593Smuzhiyun struct metapage *mp = NULL;
541*4882a593Smuzhiyun struct dir_table_slot *slot;
542*4882a593Smuzhiyun
543*4882a593Smuzhiyun slot = find_index(ip, index, &mp, &lblock);
544*4882a593Smuzhiyun if (!slot) {
545*4882a593Smuzhiyun return -EIO;
546*4882a593Smuzhiyun }
547*4882a593Smuzhiyun
548*4882a593Smuzhiyun memcpy(dirtab_slot, slot, sizeof(struct dir_table_slot));
549*4882a593Smuzhiyun
550*4882a593Smuzhiyun if (mp)
551*4882a593Smuzhiyun release_metapage(mp);
552*4882a593Smuzhiyun
553*4882a593Smuzhiyun return 0;
554*4882a593Smuzhiyun }
555*4882a593Smuzhiyun
556*4882a593Smuzhiyun /*
557*4882a593Smuzhiyun * dtSearch()
558*4882a593Smuzhiyun *
559*4882a593Smuzhiyun * function:
560*4882a593Smuzhiyun * Search for the entry with specified key
561*4882a593Smuzhiyun *
562*4882a593Smuzhiyun * parameter:
563*4882a593Smuzhiyun *
564*4882a593Smuzhiyun * return: 0 - search result on stack, leaf page pinned;
565*4882a593Smuzhiyun * errno - I/O error
566*4882a593Smuzhiyun */
dtSearch(struct inode * ip,struct component_name * key,ino_t * data,struct btstack * btstack,int flag)567*4882a593Smuzhiyun int dtSearch(struct inode *ip, struct component_name * key, ino_t * data,
568*4882a593Smuzhiyun struct btstack * btstack, int flag)
569*4882a593Smuzhiyun {
570*4882a593Smuzhiyun int rc = 0;
571*4882a593Smuzhiyun int cmp = 1; /* init for empty page */
572*4882a593Smuzhiyun s64 bn;
573*4882a593Smuzhiyun struct metapage *mp;
574*4882a593Smuzhiyun dtpage_t *p;
575*4882a593Smuzhiyun s8 *stbl;
576*4882a593Smuzhiyun int base, index, lim;
577*4882a593Smuzhiyun struct btframe *btsp;
578*4882a593Smuzhiyun pxd_t *pxd;
579*4882a593Smuzhiyun int psize = 288; /* initial in-line directory */
580*4882a593Smuzhiyun ino_t inumber;
581*4882a593Smuzhiyun struct component_name ciKey;
582*4882a593Smuzhiyun struct super_block *sb = ip->i_sb;
583*4882a593Smuzhiyun
584*4882a593Smuzhiyun ciKey.name = kmalloc_array(JFS_NAME_MAX + 1, sizeof(wchar_t),
585*4882a593Smuzhiyun GFP_NOFS);
586*4882a593Smuzhiyun if (!ciKey.name) {
587*4882a593Smuzhiyun rc = -ENOMEM;
588*4882a593Smuzhiyun goto dtSearch_Exit2;
589*4882a593Smuzhiyun }
590*4882a593Smuzhiyun
591*4882a593Smuzhiyun
592*4882a593Smuzhiyun /* uppercase search key for c-i directory */
593*4882a593Smuzhiyun UniStrcpy(ciKey.name, key->name);
594*4882a593Smuzhiyun ciKey.namlen = key->namlen;
595*4882a593Smuzhiyun
596*4882a593Smuzhiyun /* only uppercase if case-insensitive support is on */
597*4882a593Smuzhiyun if ((JFS_SBI(sb)->mntflag & JFS_OS2) == JFS_OS2) {
598*4882a593Smuzhiyun ciToUpper(&ciKey);
599*4882a593Smuzhiyun }
600*4882a593Smuzhiyun BT_CLR(btstack); /* reset stack */
601*4882a593Smuzhiyun
602*4882a593Smuzhiyun /* init level count for max pages to split */
603*4882a593Smuzhiyun btstack->nsplit = 1;
604*4882a593Smuzhiyun
605*4882a593Smuzhiyun /*
606*4882a593Smuzhiyun * search down tree from root:
607*4882a593Smuzhiyun *
608*4882a593Smuzhiyun * between two consecutive entries of <Ki, Pi> and <Kj, Pj> of
609*4882a593Smuzhiyun * internal page, child page Pi contains entry with k, Ki <= K < Kj.
610*4882a593Smuzhiyun *
611*4882a593Smuzhiyun * if entry with search key K is not found
612*4882a593Smuzhiyun * internal page search find the entry with largest key Ki
613*4882a593Smuzhiyun * less than K which point to the child page to search;
614*4882a593Smuzhiyun * leaf page search find the entry with smallest key Kj
615*4882a593Smuzhiyun * greater than K so that the returned index is the position of
616*4882a593Smuzhiyun * the entry to be shifted right for insertion of new entry.
617*4882a593Smuzhiyun * for empty tree, search key is greater than any key of the tree.
618*4882a593Smuzhiyun *
619*4882a593Smuzhiyun * by convention, root bn = 0.
620*4882a593Smuzhiyun */
621*4882a593Smuzhiyun for (bn = 0;;) {
622*4882a593Smuzhiyun /* get/pin the page to search */
623*4882a593Smuzhiyun DT_GETPAGE(ip, bn, mp, psize, p, rc);
624*4882a593Smuzhiyun if (rc)
625*4882a593Smuzhiyun goto dtSearch_Exit1;
626*4882a593Smuzhiyun
627*4882a593Smuzhiyun /* get sorted entry table of the page */
628*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
629*4882a593Smuzhiyun
630*4882a593Smuzhiyun /*
631*4882a593Smuzhiyun * binary search with search key K on the current page.
632*4882a593Smuzhiyun */
633*4882a593Smuzhiyun for (base = 0, lim = p->header.nextindex; lim; lim >>= 1) {
634*4882a593Smuzhiyun index = base + (lim >> 1);
635*4882a593Smuzhiyun
636*4882a593Smuzhiyun if (p->header.flag & BT_LEAF) {
637*4882a593Smuzhiyun /* uppercase leaf name to compare */
638*4882a593Smuzhiyun cmp =
639*4882a593Smuzhiyun ciCompare(&ciKey, p, stbl[index],
640*4882a593Smuzhiyun JFS_SBI(sb)->mntflag);
641*4882a593Smuzhiyun } else {
642*4882a593Smuzhiyun /* router key is in uppercase */
643*4882a593Smuzhiyun
644*4882a593Smuzhiyun cmp = dtCompare(&ciKey, p, stbl[index]);
645*4882a593Smuzhiyun
646*4882a593Smuzhiyun
647*4882a593Smuzhiyun }
648*4882a593Smuzhiyun if (cmp == 0) {
649*4882a593Smuzhiyun /*
650*4882a593Smuzhiyun * search hit
651*4882a593Smuzhiyun */
652*4882a593Smuzhiyun /* search hit - leaf page:
653*4882a593Smuzhiyun * return the entry found
654*4882a593Smuzhiyun */
655*4882a593Smuzhiyun if (p->header.flag & BT_LEAF) {
656*4882a593Smuzhiyun inumber = le32_to_cpu(
657*4882a593Smuzhiyun ((struct ldtentry *) & p->slot[stbl[index]])->inumber);
658*4882a593Smuzhiyun
659*4882a593Smuzhiyun /*
660*4882a593Smuzhiyun * search for JFS_LOOKUP
661*4882a593Smuzhiyun */
662*4882a593Smuzhiyun if (flag == JFS_LOOKUP) {
663*4882a593Smuzhiyun *data = inumber;
664*4882a593Smuzhiyun rc = 0;
665*4882a593Smuzhiyun goto out;
666*4882a593Smuzhiyun }
667*4882a593Smuzhiyun
668*4882a593Smuzhiyun /*
669*4882a593Smuzhiyun * search for JFS_CREATE
670*4882a593Smuzhiyun */
671*4882a593Smuzhiyun if (flag == JFS_CREATE) {
672*4882a593Smuzhiyun *data = inumber;
673*4882a593Smuzhiyun rc = -EEXIST;
674*4882a593Smuzhiyun goto out;
675*4882a593Smuzhiyun }
676*4882a593Smuzhiyun
677*4882a593Smuzhiyun /*
678*4882a593Smuzhiyun * search for JFS_REMOVE or JFS_RENAME
679*4882a593Smuzhiyun */
680*4882a593Smuzhiyun if ((flag == JFS_REMOVE ||
681*4882a593Smuzhiyun flag == JFS_RENAME) &&
682*4882a593Smuzhiyun *data != inumber) {
683*4882a593Smuzhiyun rc = -ESTALE;
684*4882a593Smuzhiyun goto out;
685*4882a593Smuzhiyun }
686*4882a593Smuzhiyun
687*4882a593Smuzhiyun /*
688*4882a593Smuzhiyun * JFS_REMOVE|JFS_FINDDIR|JFS_RENAME
689*4882a593Smuzhiyun */
690*4882a593Smuzhiyun /* save search result */
691*4882a593Smuzhiyun *data = inumber;
692*4882a593Smuzhiyun btsp = btstack->top;
693*4882a593Smuzhiyun btsp->bn = bn;
694*4882a593Smuzhiyun btsp->index = index;
695*4882a593Smuzhiyun btsp->mp = mp;
696*4882a593Smuzhiyun
697*4882a593Smuzhiyun rc = 0;
698*4882a593Smuzhiyun goto dtSearch_Exit1;
699*4882a593Smuzhiyun }
700*4882a593Smuzhiyun
701*4882a593Smuzhiyun /* search hit - internal page:
702*4882a593Smuzhiyun * descend/search its child page
703*4882a593Smuzhiyun */
704*4882a593Smuzhiyun goto getChild;
705*4882a593Smuzhiyun }
706*4882a593Smuzhiyun
707*4882a593Smuzhiyun if (cmp > 0) {
708*4882a593Smuzhiyun base = index + 1;
709*4882a593Smuzhiyun --lim;
710*4882a593Smuzhiyun }
711*4882a593Smuzhiyun }
712*4882a593Smuzhiyun
713*4882a593Smuzhiyun /*
714*4882a593Smuzhiyun * search miss
715*4882a593Smuzhiyun *
716*4882a593Smuzhiyun * base is the smallest index with key (Kj) greater than
717*4882a593Smuzhiyun * search key (K) and may be zero or (maxindex + 1) index.
718*4882a593Smuzhiyun */
719*4882a593Smuzhiyun /*
720*4882a593Smuzhiyun * search miss - leaf page
721*4882a593Smuzhiyun *
722*4882a593Smuzhiyun * return location of entry (base) where new entry with
723*4882a593Smuzhiyun * search key K is to be inserted.
724*4882a593Smuzhiyun */
725*4882a593Smuzhiyun if (p->header.flag & BT_LEAF) {
726*4882a593Smuzhiyun /*
727*4882a593Smuzhiyun * search for JFS_LOOKUP, JFS_REMOVE, or JFS_RENAME
728*4882a593Smuzhiyun */
729*4882a593Smuzhiyun if (flag == JFS_LOOKUP || flag == JFS_REMOVE ||
730*4882a593Smuzhiyun flag == JFS_RENAME) {
731*4882a593Smuzhiyun rc = -ENOENT;
732*4882a593Smuzhiyun goto out;
733*4882a593Smuzhiyun }
734*4882a593Smuzhiyun
735*4882a593Smuzhiyun /*
736*4882a593Smuzhiyun * search for JFS_CREATE|JFS_FINDDIR:
737*4882a593Smuzhiyun *
738*4882a593Smuzhiyun * save search result
739*4882a593Smuzhiyun */
740*4882a593Smuzhiyun *data = 0;
741*4882a593Smuzhiyun btsp = btstack->top;
742*4882a593Smuzhiyun btsp->bn = bn;
743*4882a593Smuzhiyun btsp->index = base;
744*4882a593Smuzhiyun btsp->mp = mp;
745*4882a593Smuzhiyun
746*4882a593Smuzhiyun rc = 0;
747*4882a593Smuzhiyun goto dtSearch_Exit1;
748*4882a593Smuzhiyun }
749*4882a593Smuzhiyun
750*4882a593Smuzhiyun /*
751*4882a593Smuzhiyun * search miss - internal page
752*4882a593Smuzhiyun *
753*4882a593Smuzhiyun * if base is non-zero, decrement base by one to get the parent
754*4882a593Smuzhiyun * entry of the child page to search.
755*4882a593Smuzhiyun */
756*4882a593Smuzhiyun index = base ? base - 1 : base;
757*4882a593Smuzhiyun
758*4882a593Smuzhiyun /*
759*4882a593Smuzhiyun * go down to child page
760*4882a593Smuzhiyun */
761*4882a593Smuzhiyun getChild:
762*4882a593Smuzhiyun /* update max. number of pages to split */
763*4882a593Smuzhiyun if (BT_STACK_FULL(btstack)) {
764*4882a593Smuzhiyun /* Something's corrupted, mark filesystem dirty so
765*4882a593Smuzhiyun * chkdsk will fix it.
766*4882a593Smuzhiyun */
767*4882a593Smuzhiyun jfs_error(sb, "stack overrun!\n");
768*4882a593Smuzhiyun BT_STACK_DUMP(btstack);
769*4882a593Smuzhiyun rc = -EIO;
770*4882a593Smuzhiyun goto out;
771*4882a593Smuzhiyun }
772*4882a593Smuzhiyun btstack->nsplit++;
773*4882a593Smuzhiyun
774*4882a593Smuzhiyun /* push (bn, index) of the parent page/entry */
775*4882a593Smuzhiyun BT_PUSH(btstack, bn, index);
776*4882a593Smuzhiyun
777*4882a593Smuzhiyun /* get the child page block number */
778*4882a593Smuzhiyun pxd = (pxd_t *) & p->slot[stbl[index]];
779*4882a593Smuzhiyun bn = addressPXD(pxd);
780*4882a593Smuzhiyun psize = lengthPXD(pxd) << JFS_SBI(ip->i_sb)->l2bsize;
781*4882a593Smuzhiyun
782*4882a593Smuzhiyun /* unpin the parent page */
783*4882a593Smuzhiyun DT_PUTPAGE(mp);
784*4882a593Smuzhiyun }
785*4882a593Smuzhiyun
786*4882a593Smuzhiyun out:
787*4882a593Smuzhiyun DT_PUTPAGE(mp);
788*4882a593Smuzhiyun
789*4882a593Smuzhiyun dtSearch_Exit1:
790*4882a593Smuzhiyun
791*4882a593Smuzhiyun kfree(ciKey.name);
792*4882a593Smuzhiyun
793*4882a593Smuzhiyun dtSearch_Exit2:
794*4882a593Smuzhiyun
795*4882a593Smuzhiyun return rc;
796*4882a593Smuzhiyun }
797*4882a593Smuzhiyun
798*4882a593Smuzhiyun
799*4882a593Smuzhiyun /*
800*4882a593Smuzhiyun * dtInsert()
801*4882a593Smuzhiyun *
802*4882a593Smuzhiyun * function: insert an entry to directory tree
803*4882a593Smuzhiyun *
804*4882a593Smuzhiyun * parameter:
805*4882a593Smuzhiyun *
806*4882a593Smuzhiyun * return: 0 - success;
807*4882a593Smuzhiyun * errno - failure;
808*4882a593Smuzhiyun */
dtInsert(tid_t tid,struct inode * ip,struct component_name * name,ino_t * fsn,struct btstack * btstack)809*4882a593Smuzhiyun int dtInsert(tid_t tid, struct inode *ip,
810*4882a593Smuzhiyun struct component_name * name, ino_t * fsn, struct btstack * btstack)
811*4882a593Smuzhiyun {
812*4882a593Smuzhiyun int rc = 0;
813*4882a593Smuzhiyun struct metapage *mp; /* meta-page buffer */
814*4882a593Smuzhiyun dtpage_t *p; /* base B+-tree index page */
815*4882a593Smuzhiyun s64 bn;
816*4882a593Smuzhiyun int index;
817*4882a593Smuzhiyun struct dtsplit split; /* split information */
818*4882a593Smuzhiyun ddata_t data;
819*4882a593Smuzhiyun struct dt_lock *dtlck;
820*4882a593Smuzhiyun int n;
821*4882a593Smuzhiyun struct tlock *tlck;
822*4882a593Smuzhiyun struct lv *lv;
823*4882a593Smuzhiyun
824*4882a593Smuzhiyun /*
825*4882a593Smuzhiyun * retrieve search result
826*4882a593Smuzhiyun *
827*4882a593Smuzhiyun * dtSearch() returns (leaf page pinned, index at which to insert).
828*4882a593Smuzhiyun * n.b. dtSearch() may return index of (maxindex + 1) of
829*4882a593Smuzhiyun * the full page.
830*4882a593Smuzhiyun */
831*4882a593Smuzhiyun DT_GETSEARCH(ip, btstack->top, bn, mp, p, index);
832*4882a593Smuzhiyun
833*4882a593Smuzhiyun /*
834*4882a593Smuzhiyun * insert entry for new key
835*4882a593Smuzhiyun */
836*4882a593Smuzhiyun if (DO_INDEX(ip)) {
837*4882a593Smuzhiyun if (JFS_IP(ip)->next_index == DIREND) {
838*4882a593Smuzhiyun DT_PUTPAGE(mp);
839*4882a593Smuzhiyun return -EMLINK;
840*4882a593Smuzhiyun }
841*4882a593Smuzhiyun n = NDTLEAF(name->namlen);
842*4882a593Smuzhiyun data.leaf.tid = tid;
843*4882a593Smuzhiyun data.leaf.ip = ip;
844*4882a593Smuzhiyun } else {
845*4882a593Smuzhiyun n = NDTLEAF_LEGACY(name->namlen);
846*4882a593Smuzhiyun data.leaf.ip = NULL; /* signifies legacy directory format */
847*4882a593Smuzhiyun }
848*4882a593Smuzhiyun data.leaf.ino = *fsn;
849*4882a593Smuzhiyun
850*4882a593Smuzhiyun /*
851*4882a593Smuzhiyun * leaf page does not have enough room for new entry:
852*4882a593Smuzhiyun *
853*4882a593Smuzhiyun * extend/split the leaf page;
854*4882a593Smuzhiyun *
855*4882a593Smuzhiyun * dtSplitUp() will insert the entry and unpin the leaf page.
856*4882a593Smuzhiyun */
857*4882a593Smuzhiyun if (n > p->header.freecnt) {
858*4882a593Smuzhiyun split.mp = mp;
859*4882a593Smuzhiyun split.index = index;
860*4882a593Smuzhiyun split.nslot = n;
861*4882a593Smuzhiyun split.key = name;
862*4882a593Smuzhiyun split.data = &data;
863*4882a593Smuzhiyun rc = dtSplitUp(tid, ip, &split, btstack);
864*4882a593Smuzhiyun return rc;
865*4882a593Smuzhiyun }
866*4882a593Smuzhiyun
867*4882a593Smuzhiyun /*
868*4882a593Smuzhiyun * leaf page does have enough room for new entry:
869*4882a593Smuzhiyun *
870*4882a593Smuzhiyun * insert the new data entry into the leaf page;
871*4882a593Smuzhiyun */
872*4882a593Smuzhiyun BT_MARK_DIRTY(mp, ip);
873*4882a593Smuzhiyun /*
874*4882a593Smuzhiyun * acquire a transaction lock on the leaf page
875*4882a593Smuzhiyun */
876*4882a593Smuzhiyun tlck = txLock(tid, ip, mp, tlckDTREE | tlckENTRY);
877*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
878*4882a593Smuzhiyun ASSERT(dtlck->index == 0);
879*4882a593Smuzhiyun lv = & dtlck->lv[0];
880*4882a593Smuzhiyun
881*4882a593Smuzhiyun /* linelock header */
882*4882a593Smuzhiyun lv->offset = 0;
883*4882a593Smuzhiyun lv->length = 1;
884*4882a593Smuzhiyun dtlck->index++;
885*4882a593Smuzhiyun
886*4882a593Smuzhiyun dtInsertEntry(p, index, name, &data, &dtlck);
887*4882a593Smuzhiyun
888*4882a593Smuzhiyun /* linelock stbl of non-root leaf page */
889*4882a593Smuzhiyun if (!(p->header.flag & BT_ROOT)) {
890*4882a593Smuzhiyun if (dtlck->index >= dtlck->maxcnt)
891*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
892*4882a593Smuzhiyun lv = & dtlck->lv[dtlck->index];
893*4882a593Smuzhiyun n = index >> L2DTSLOTSIZE;
894*4882a593Smuzhiyun lv->offset = p->header.stblindex + n;
895*4882a593Smuzhiyun lv->length =
896*4882a593Smuzhiyun ((p->header.nextindex - 1) >> L2DTSLOTSIZE) - n + 1;
897*4882a593Smuzhiyun dtlck->index++;
898*4882a593Smuzhiyun }
899*4882a593Smuzhiyun
900*4882a593Smuzhiyun /* unpin the leaf page */
901*4882a593Smuzhiyun DT_PUTPAGE(mp);
902*4882a593Smuzhiyun
903*4882a593Smuzhiyun return 0;
904*4882a593Smuzhiyun }
905*4882a593Smuzhiyun
906*4882a593Smuzhiyun
907*4882a593Smuzhiyun /*
908*4882a593Smuzhiyun * dtSplitUp()
909*4882a593Smuzhiyun *
910*4882a593Smuzhiyun * function: propagate insertion bottom up;
911*4882a593Smuzhiyun *
912*4882a593Smuzhiyun * parameter:
913*4882a593Smuzhiyun *
914*4882a593Smuzhiyun * return: 0 - success;
915*4882a593Smuzhiyun * errno - failure;
916*4882a593Smuzhiyun * leaf page unpinned;
917*4882a593Smuzhiyun */
dtSplitUp(tid_t tid,struct inode * ip,struct dtsplit * split,struct btstack * btstack)918*4882a593Smuzhiyun static int dtSplitUp(tid_t tid,
919*4882a593Smuzhiyun struct inode *ip, struct dtsplit * split, struct btstack * btstack)
920*4882a593Smuzhiyun {
921*4882a593Smuzhiyun struct jfs_sb_info *sbi = JFS_SBI(ip->i_sb);
922*4882a593Smuzhiyun int rc = 0;
923*4882a593Smuzhiyun struct metapage *smp;
924*4882a593Smuzhiyun dtpage_t *sp; /* split page */
925*4882a593Smuzhiyun struct metapage *rmp;
926*4882a593Smuzhiyun dtpage_t *rp; /* new right page split from sp */
927*4882a593Smuzhiyun pxd_t rpxd; /* new right page extent descriptor */
928*4882a593Smuzhiyun struct metapage *lmp;
929*4882a593Smuzhiyun dtpage_t *lp; /* left child page */
930*4882a593Smuzhiyun int skip; /* index of entry of insertion */
931*4882a593Smuzhiyun struct btframe *parent; /* parent page entry on traverse stack */
932*4882a593Smuzhiyun s64 xaddr, nxaddr;
933*4882a593Smuzhiyun int xlen, xsize;
934*4882a593Smuzhiyun struct pxdlist pxdlist;
935*4882a593Smuzhiyun pxd_t *pxd;
936*4882a593Smuzhiyun struct component_name key = { 0, NULL };
937*4882a593Smuzhiyun ddata_t *data = split->data;
938*4882a593Smuzhiyun int n;
939*4882a593Smuzhiyun struct dt_lock *dtlck;
940*4882a593Smuzhiyun struct tlock *tlck;
941*4882a593Smuzhiyun struct lv *lv;
942*4882a593Smuzhiyun int quota_allocation = 0;
943*4882a593Smuzhiyun
944*4882a593Smuzhiyun /* get split page */
945*4882a593Smuzhiyun smp = split->mp;
946*4882a593Smuzhiyun sp = DT_PAGE(ip, smp);
947*4882a593Smuzhiyun
948*4882a593Smuzhiyun key.name = kmalloc_array(JFS_NAME_MAX + 2, sizeof(wchar_t), GFP_NOFS);
949*4882a593Smuzhiyun if (!key.name) {
950*4882a593Smuzhiyun DT_PUTPAGE(smp);
951*4882a593Smuzhiyun rc = -ENOMEM;
952*4882a593Smuzhiyun goto dtSplitUp_Exit;
953*4882a593Smuzhiyun }
954*4882a593Smuzhiyun
955*4882a593Smuzhiyun /*
956*4882a593Smuzhiyun * split leaf page
957*4882a593Smuzhiyun *
958*4882a593Smuzhiyun * The split routines insert the new entry, and
959*4882a593Smuzhiyun * acquire txLock as appropriate.
960*4882a593Smuzhiyun */
961*4882a593Smuzhiyun /*
962*4882a593Smuzhiyun * split root leaf page:
963*4882a593Smuzhiyun */
964*4882a593Smuzhiyun if (sp->header.flag & BT_ROOT) {
965*4882a593Smuzhiyun /*
966*4882a593Smuzhiyun * allocate a single extent child page
967*4882a593Smuzhiyun */
968*4882a593Smuzhiyun xlen = 1;
969*4882a593Smuzhiyun n = sbi->bsize >> L2DTSLOTSIZE;
970*4882a593Smuzhiyun n -= (n + 31) >> L2DTSLOTSIZE; /* stbl size */
971*4882a593Smuzhiyun n -= DTROOTMAXSLOT - sp->header.freecnt; /* header + entries */
972*4882a593Smuzhiyun if (n <= split->nslot)
973*4882a593Smuzhiyun xlen++;
974*4882a593Smuzhiyun if ((rc = dbAlloc(ip, 0, (s64) xlen, &xaddr))) {
975*4882a593Smuzhiyun DT_PUTPAGE(smp);
976*4882a593Smuzhiyun goto freeKeyName;
977*4882a593Smuzhiyun }
978*4882a593Smuzhiyun
979*4882a593Smuzhiyun pxdlist.maxnpxd = 1;
980*4882a593Smuzhiyun pxdlist.npxd = 0;
981*4882a593Smuzhiyun pxd = &pxdlist.pxd[0];
982*4882a593Smuzhiyun PXDaddress(pxd, xaddr);
983*4882a593Smuzhiyun PXDlength(pxd, xlen);
984*4882a593Smuzhiyun split->pxdlist = &pxdlist;
985*4882a593Smuzhiyun rc = dtSplitRoot(tid, ip, split, &rmp);
986*4882a593Smuzhiyun
987*4882a593Smuzhiyun if (rc)
988*4882a593Smuzhiyun dbFree(ip, xaddr, xlen);
989*4882a593Smuzhiyun else
990*4882a593Smuzhiyun DT_PUTPAGE(rmp);
991*4882a593Smuzhiyun
992*4882a593Smuzhiyun DT_PUTPAGE(smp);
993*4882a593Smuzhiyun
994*4882a593Smuzhiyun if (!DO_INDEX(ip))
995*4882a593Smuzhiyun ip->i_size = xlen << sbi->l2bsize;
996*4882a593Smuzhiyun
997*4882a593Smuzhiyun goto freeKeyName;
998*4882a593Smuzhiyun }
999*4882a593Smuzhiyun
1000*4882a593Smuzhiyun /*
1001*4882a593Smuzhiyun * extend first leaf page
1002*4882a593Smuzhiyun *
1003*4882a593Smuzhiyun * extend the 1st extent if less than buffer page size
1004*4882a593Smuzhiyun * (dtExtendPage() reurns leaf page unpinned)
1005*4882a593Smuzhiyun */
1006*4882a593Smuzhiyun pxd = &sp->header.self;
1007*4882a593Smuzhiyun xlen = lengthPXD(pxd);
1008*4882a593Smuzhiyun xsize = xlen << sbi->l2bsize;
1009*4882a593Smuzhiyun if (xsize < PSIZE) {
1010*4882a593Smuzhiyun xaddr = addressPXD(pxd);
1011*4882a593Smuzhiyun n = xsize >> L2DTSLOTSIZE;
1012*4882a593Smuzhiyun n -= (n + 31) >> L2DTSLOTSIZE; /* stbl size */
1013*4882a593Smuzhiyun if ((n + sp->header.freecnt) <= split->nslot)
1014*4882a593Smuzhiyun n = xlen + (xlen << 1);
1015*4882a593Smuzhiyun else
1016*4882a593Smuzhiyun n = xlen;
1017*4882a593Smuzhiyun
1018*4882a593Smuzhiyun /* Allocate blocks to quota. */
1019*4882a593Smuzhiyun rc = dquot_alloc_block(ip, n);
1020*4882a593Smuzhiyun if (rc)
1021*4882a593Smuzhiyun goto extendOut;
1022*4882a593Smuzhiyun quota_allocation += n;
1023*4882a593Smuzhiyun
1024*4882a593Smuzhiyun if ((rc = dbReAlloc(sbi->ipbmap, xaddr, (s64) xlen,
1025*4882a593Smuzhiyun (s64) n, &nxaddr)))
1026*4882a593Smuzhiyun goto extendOut;
1027*4882a593Smuzhiyun
1028*4882a593Smuzhiyun pxdlist.maxnpxd = 1;
1029*4882a593Smuzhiyun pxdlist.npxd = 0;
1030*4882a593Smuzhiyun pxd = &pxdlist.pxd[0];
1031*4882a593Smuzhiyun PXDaddress(pxd, nxaddr);
1032*4882a593Smuzhiyun PXDlength(pxd, xlen + n);
1033*4882a593Smuzhiyun split->pxdlist = &pxdlist;
1034*4882a593Smuzhiyun if ((rc = dtExtendPage(tid, ip, split, btstack))) {
1035*4882a593Smuzhiyun nxaddr = addressPXD(pxd);
1036*4882a593Smuzhiyun if (xaddr != nxaddr) {
1037*4882a593Smuzhiyun /* free relocated extent */
1038*4882a593Smuzhiyun xlen = lengthPXD(pxd);
1039*4882a593Smuzhiyun dbFree(ip, nxaddr, (s64) xlen);
1040*4882a593Smuzhiyun } else {
1041*4882a593Smuzhiyun /* free extended delta */
1042*4882a593Smuzhiyun xlen = lengthPXD(pxd) - n;
1043*4882a593Smuzhiyun xaddr = addressPXD(pxd) + xlen;
1044*4882a593Smuzhiyun dbFree(ip, xaddr, (s64) n);
1045*4882a593Smuzhiyun }
1046*4882a593Smuzhiyun } else if (!DO_INDEX(ip))
1047*4882a593Smuzhiyun ip->i_size = lengthPXD(pxd) << sbi->l2bsize;
1048*4882a593Smuzhiyun
1049*4882a593Smuzhiyun
1050*4882a593Smuzhiyun extendOut:
1051*4882a593Smuzhiyun DT_PUTPAGE(smp);
1052*4882a593Smuzhiyun goto freeKeyName;
1053*4882a593Smuzhiyun }
1054*4882a593Smuzhiyun
1055*4882a593Smuzhiyun /*
1056*4882a593Smuzhiyun * split leaf page <sp> into <sp> and a new right page <rp>.
1057*4882a593Smuzhiyun *
1058*4882a593Smuzhiyun * return <rp> pinned and its extent descriptor <rpxd>
1059*4882a593Smuzhiyun */
1060*4882a593Smuzhiyun /*
1061*4882a593Smuzhiyun * allocate new directory page extent and
1062*4882a593Smuzhiyun * new index page(s) to cover page split(s)
1063*4882a593Smuzhiyun *
1064*4882a593Smuzhiyun * allocation hint: ?
1065*4882a593Smuzhiyun */
1066*4882a593Smuzhiyun n = btstack->nsplit;
1067*4882a593Smuzhiyun pxdlist.maxnpxd = pxdlist.npxd = 0;
1068*4882a593Smuzhiyun xlen = sbi->nbperpage;
1069*4882a593Smuzhiyun for (pxd = pxdlist.pxd; n > 0; n--, pxd++) {
1070*4882a593Smuzhiyun if ((rc = dbAlloc(ip, 0, (s64) xlen, &xaddr)) == 0) {
1071*4882a593Smuzhiyun PXDaddress(pxd, xaddr);
1072*4882a593Smuzhiyun PXDlength(pxd, xlen);
1073*4882a593Smuzhiyun pxdlist.maxnpxd++;
1074*4882a593Smuzhiyun continue;
1075*4882a593Smuzhiyun }
1076*4882a593Smuzhiyun
1077*4882a593Smuzhiyun DT_PUTPAGE(smp);
1078*4882a593Smuzhiyun
1079*4882a593Smuzhiyun /* undo allocation */
1080*4882a593Smuzhiyun goto splitOut;
1081*4882a593Smuzhiyun }
1082*4882a593Smuzhiyun
1083*4882a593Smuzhiyun split->pxdlist = &pxdlist;
1084*4882a593Smuzhiyun if ((rc = dtSplitPage(tid, ip, split, &rmp, &rp, &rpxd))) {
1085*4882a593Smuzhiyun DT_PUTPAGE(smp);
1086*4882a593Smuzhiyun
1087*4882a593Smuzhiyun /* undo allocation */
1088*4882a593Smuzhiyun goto splitOut;
1089*4882a593Smuzhiyun }
1090*4882a593Smuzhiyun
1091*4882a593Smuzhiyun if (!DO_INDEX(ip))
1092*4882a593Smuzhiyun ip->i_size += PSIZE;
1093*4882a593Smuzhiyun
1094*4882a593Smuzhiyun /*
1095*4882a593Smuzhiyun * propagate up the router entry for the leaf page just split
1096*4882a593Smuzhiyun *
1097*4882a593Smuzhiyun * insert a router entry for the new page into the parent page,
1098*4882a593Smuzhiyun * propagate the insert/split up the tree by walking back the stack
1099*4882a593Smuzhiyun * of (bn of parent page, index of child page entry in parent page)
1100*4882a593Smuzhiyun * that were traversed during the search for the page that split.
1101*4882a593Smuzhiyun *
1102*4882a593Smuzhiyun * the propagation of insert/split up the tree stops if the root
1103*4882a593Smuzhiyun * splits or the page inserted into doesn't have to split to hold
1104*4882a593Smuzhiyun * the new entry.
1105*4882a593Smuzhiyun *
1106*4882a593Smuzhiyun * the parent entry for the split page remains the same, and
1107*4882a593Smuzhiyun * a new entry is inserted at its right with the first key and
1108*4882a593Smuzhiyun * block number of the new right page.
1109*4882a593Smuzhiyun *
1110*4882a593Smuzhiyun * There are a maximum of 4 pages pinned at any time:
1111*4882a593Smuzhiyun * two children, left parent and right parent (when the parent splits).
1112*4882a593Smuzhiyun * keep the child pages pinned while working on the parent.
1113*4882a593Smuzhiyun * make sure that all pins are released at exit.
1114*4882a593Smuzhiyun */
1115*4882a593Smuzhiyun while ((parent = BT_POP(btstack)) != NULL) {
1116*4882a593Smuzhiyun /* parent page specified by stack frame <parent> */
1117*4882a593Smuzhiyun
1118*4882a593Smuzhiyun /* keep current child pages (<lp>, <rp>) pinned */
1119*4882a593Smuzhiyun lmp = smp;
1120*4882a593Smuzhiyun lp = sp;
1121*4882a593Smuzhiyun
1122*4882a593Smuzhiyun /*
1123*4882a593Smuzhiyun * insert router entry in parent for new right child page <rp>
1124*4882a593Smuzhiyun */
1125*4882a593Smuzhiyun /* get the parent page <sp> */
1126*4882a593Smuzhiyun DT_GETPAGE(ip, parent->bn, smp, PSIZE, sp, rc);
1127*4882a593Smuzhiyun if (rc) {
1128*4882a593Smuzhiyun DT_PUTPAGE(lmp);
1129*4882a593Smuzhiyun DT_PUTPAGE(rmp);
1130*4882a593Smuzhiyun goto splitOut;
1131*4882a593Smuzhiyun }
1132*4882a593Smuzhiyun
1133*4882a593Smuzhiyun /*
1134*4882a593Smuzhiyun * The new key entry goes ONE AFTER the index of parent entry,
1135*4882a593Smuzhiyun * because the split was to the right.
1136*4882a593Smuzhiyun */
1137*4882a593Smuzhiyun skip = parent->index + 1;
1138*4882a593Smuzhiyun
1139*4882a593Smuzhiyun /*
1140*4882a593Smuzhiyun * compute the key for the router entry
1141*4882a593Smuzhiyun *
1142*4882a593Smuzhiyun * key suffix compression:
1143*4882a593Smuzhiyun * for internal pages that have leaf pages as children,
1144*4882a593Smuzhiyun * retain only what's needed to distinguish between
1145*4882a593Smuzhiyun * the new entry and the entry on the page to its left.
1146*4882a593Smuzhiyun * If the keys compare equal, retain the entire key.
1147*4882a593Smuzhiyun *
1148*4882a593Smuzhiyun * note that compression is performed only at computing
1149*4882a593Smuzhiyun * router key at the lowest internal level.
1150*4882a593Smuzhiyun * further compression of the key between pairs of higher
1151*4882a593Smuzhiyun * level internal pages loses too much information and
1152*4882a593Smuzhiyun * the search may fail.
1153*4882a593Smuzhiyun * (e.g., two adjacent leaf pages of {a, ..., x} {xx, ...,}
1154*4882a593Smuzhiyun * results in two adjacent parent entries (a)(xx).
1155*4882a593Smuzhiyun * if split occurs between these two entries, and
1156*4882a593Smuzhiyun * if compression is applied, the router key of parent entry
1157*4882a593Smuzhiyun * of right page (x) will divert search for x into right
1158*4882a593Smuzhiyun * subtree and miss x in the left subtree.)
1159*4882a593Smuzhiyun *
1160*4882a593Smuzhiyun * the entire key must be retained for the next-to-leftmost
1161*4882a593Smuzhiyun * internal key at any level of the tree, or search may fail
1162*4882a593Smuzhiyun * (e.g., ?)
1163*4882a593Smuzhiyun */
1164*4882a593Smuzhiyun switch (rp->header.flag & BT_TYPE) {
1165*4882a593Smuzhiyun case BT_LEAF:
1166*4882a593Smuzhiyun /*
1167*4882a593Smuzhiyun * compute the length of prefix for suffix compression
1168*4882a593Smuzhiyun * between last entry of left page and first entry
1169*4882a593Smuzhiyun * of right page
1170*4882a593Smuzhiyun */
1171*4882a593Smuzhiyun if ((sp->header.flag & BT_ROOT && skip > 1) ||
1172*4882a593Smuzhiyun sp->header.prev != 0 || skip > 1) {
1173*4882a593Smuzhiyun /* compute uppercase router prefix key */
1174*4882a593Smuzhiyun rc = ciGetLeafPrefixKey(lp,
1175*4882a593Smuzhiyun lp->header.nextindex-1,
1176*4882a593Smuzhiyun rp, 0, &key,
1177*4882a593Smuzhiyun sbi->mntflag);
1178*4882a593Smuzhiyun if (rc) {
1179*4882a593Smuzhiyun DT_PUTPAGE(lmp);
1180*4882a593Smuzhiyun DT_PUTPAGE(rmp);
1181*4882a593Smuzhiyun DT_PUTPAGE(smp);
1182*4882a593Smuzhiyun goto splitOut;
1183*4882a593Smuzhiyun }
1184*4882a593Smuzhiyun } else {
1185*4882a593Smuzhiyun /* next to leftmost entry of
1186*4882a593Smuzhiyun lowest internal level */
1187*4882a593Smuzhiyun
1188*4882a593Smuzhiyun /* compute uppercase router key */
1189*4882a593Smuzhiyun dtGetKey(rp, 0, &key, sbi->mntflag);
1190*4882a593Smuzhiyun key.name[key.namlen] = 0;
1191*4882a593Smuzhiyun
1192*4882a593Smuzhiyun if ((sbi->mntflag & JFS_OS2) == JFS_OS2)
1193*4882a593Smuzhiyun ciToUpper(&key);
1194*4882a593Smuzhiyun }
1195*4882a593Smuzhiyun
1196*4882a593Smuzhiyun n = NDTINTERNAL(key.namlen);
1197*4882a593Smuzhiyun break;
1198*4882a593Smuzhiyun
1199*4882a593Smuzhiyun case BT_INTERNAL:
1200*4882a593Smuzhiyun dtGetKey(rp, 0, &key, sbi->mntflag);
1201*4882a593Smuzhiyun n = NDTINTERNAL(key.namlen);
1202*4882a593Smuzhiyun break;
1203*4882a593Smuzhiyun
1204*4882a593Smuzhiyun default:
1205*4882a593Smuzhiyun jfs_err("dtSplitUp(): UFO!");
1206*4882a593Smuzhiyun break;
1207*4882a593Smuzhiyun }
1208*4882a593Smuzhiyun
1209*4882a593Smuzhiyun /* unpin left child page */
1210*4882a593Smuzhiyun DT_PUTPAGE(lmp);
1211*4882a593Smuzhiyun
1212*4882a593Smuzhiyun /*
1213*4882a593Smuzhiyun * compute the data for the router entry
1214*4882a593Smuzhiyun */
1215*4882a593Smuzhiyun data->xd = rpxd; /* child page xd */
1216*4882a593Smuzhiyun
1217*4882a593Smuzhiyun /*
1218*4882a593Smuzhiyun * parent page is full - split the parent page
1219*4882a593Smuzhiyun */
1220*4882a593Smuzhiyun if (n > sp->header.freecnt) {
1221*4882a593Smuzhiyun /* init for parent page split */
1222*4882a593Smuzhiyun split->mp = smp;
1223*4882a593Smuzhiyun split->index = skip; /* index at insert */
1224*4882a593Smuzhiyun split->nslot = n;
1225*4882a593Smuzhiyun split->key = &key;
1226*4882a593Smuzhiyun /* split->data = data; */
1227*4882a593Smuzhiyun
1228*4882a593Smuzhiyun /* unpin right child page */
1229*4882a593Smuzhiyun DT_PUTPAGE(rmp);
1230*4882a593Smuzhiyun
1231*4882a593Smuzhiyun /* The split routines insert the new entry,
1232*4882a593Smuzhiyun * acquire txLock as appropriate.
1233*4882a593Smuzhiyun * return <rp> pinned and its block number <rbn>.
1234*4882a593Smuzhiyun */
1235*4882a593Smuzhiyun rc = (sp->header.flag & BT_ROOT) ?
1236*4882a593Smuzhiyun dtSplitRoot(tid, ip, split, &rmp) :
1237*4882a593Smuzhiyun dtSplitPage(tid, ip, split, &rmp, &rp, &rpxd);
1238*4882a593Smuzhiyun if (rc) {
1239*4882a593Smuzhiyun DT_PUTPAGE(smp);
1240*4882a593Smuzhiyun goto splitOut;
1241*4882a593Smuzhiyun }
1242*4882a593Smuzhiyun
1243*4882a593Smuzhiyun /* smp and rmp are pinned */
1244*4882a593Smuzhiyun }
1245*4882a593Smuzhiyun /*
1246*4882a593Smuzhiyun * parent page is not full - insert router entry in parent page
1247*4882a593Smuzhiyun */
1248*4882a593Smuzhiyun else {
1249*4882a593Smuzhiyun BT_MARK_DIRTY(smp, ip);
1250*4882a593Smuzhiyun /*
1251*4882a593Smuzhiyun * acquire a transaction lock on the parent page
1252*4882a593Smuzhiyun */
1253*4882a593Smuzhiyun tlck = txLock(tid, ip, smp, tlckDTREE | tlckENTRY);
1254*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
1255*4882a593Smuzhiyun ASSERT(dtlck->index == 0);
1256*4882a593Smuzhiyun lv = & dtlck->lv[0];
1257*4882a593Smuzhiyun
1258*4882a593Smuzhiyun /* linelock header */
1259*4882a593Smuzhiyun lv->offset = 0;
1260*4882a593Smuzhiyun lv->length = 1;
1261*4882a593Smuzhiyun dtlck->index++;
1262*4882a593Smuzhiyun
1263*4882a593Smuzhiyun /* linelock stbl of non-root parent page */
1264*4882a593Smuzhiyun if (!(sp->header.flag & BT_ROOT)) {
1265*4882a593Smuzhiyun lv++;
1266*4882a593Smuzhiyun n = skip >> L2DTSLOTSIZE;
1267*4882a593Smuzhiyun lv->offset = sp->header.stblindex + n;
1268*4882a593Smuzhiyun lv->length =
1269*4882a593Smuzhiyun ((sp->header.nextindex -
1270*4882a593Smuzhiyun 1) >> L2DTSLOTSIZE) - n + 1;
1271*4882a593Smuzhiyun dtlck->index++;
1272*4882a593Smuzhiyun }
1273*4882a593Smuzhiyun
1274*4882a593Smuzhiyun dtInsertEntry(sp, skip, &key, data, &dtlck);
1275*4882a593Smuzhiyun
1276*4882a593Smuzhiyun /* exit propagate up */
1277*4882a593Smuzhiyun break;
1278*4882a593Smuzhiyun }
1279*4882a593Smuzhiyun }
1280*4882a593Smuzhiyun
1281*4882a593Smuzhiyun /* unpin current split and its right page */
1282*4882a593Smuzhiyun DT_PUTPAGE(smp);
1283*4882a593Smuzhiyun DT_PUTPAGE(rmp);
1284*4882a593Smuzhiyun
1285*4882a593Smuzhiyun /*
1286*4882a593Smuzhiyun * free remaining extents allocated for split
1287*4882a593Smuzhiyun */
1288*4882a593Smuzhiyun splitOut:
1289*4882a593Smuzhiyun n = pxdlist.npxd;
1290*4882a593Smuzhiyun pxd = &pxdlist.pxd[n];
1291*4882a593Smuzhiyun for (; n < pxdlist.maxnpxd; n++, pxd++)
1292*4882a593Smuzhiyun dbFree(ip, addressPXD(pxd), (s64) lengthPXD(pxd));
1293*4882a593Smuzhiyun
1294*4882a593Smuzhiyun freeKeyName:
1295*4882a593Smuzhiyun kfree(key.name);
1296*4882a593Smuzhiyun
1297*4882a593Smuzhiyun /* Rollback quota allocation */
1298*4882a593Smuzhiyun if (rc && quota_allocation)
1299*4882a593Smuzhiyun dquot_free_block(ip, quota_allocation);
1300*4882a593Smuzhiyun
1301*4882a593Smuzhiyun dtSplitUp_Exit:
1302*4882a593Smuzhiyun
1303*4882a593Smuzhiyun return rc;
1304*4882a593Smuzhiyun }
1305*4882a593Smuzhiyun
1306*4882a593Smuzhiyun
1307*4882a593Smuzhiyun /*
1308*4882a593Smuzhiyun * dtSplitPage()
1309*4882a593Smuzhiyun *
1310*4882a593Smuzhiyun * function: Split a non-root page of a btree.
1311*4882a593Smuzhiyun *
1312*4882a593Smuzhiyun * parameter:
1313*4882a593Smuzhiyun *
1314*4882a593Smuzhiyun * return: 0 - success;
1315*4882a593Smuzhiyun * errno - failure;
1316*4882a593Smuzhiyun * return split and new page pinned;
1317*4882a593Smuzhiyun */
dtSplitPage(tid_t tid,struct inode * ip,struct dtsplit * split,struct metapage ** rmpp,dtpage_t ** rpp,pxd_t * rpxdp)1318*4882a593Smuzhiyun static int dtSplitPage(tid_t tid, struct inode *ip, struct dtsplit * split,
1319*4882a593Smuzhiyun struct metapage ** rmpp, dtpage_t ** rpp, pxd_t * rpxdp)
1320*4882a593Smuzhiyun {
1321*4882a593Smuzhiyun int rc = 0;
1322*4882a593Smuzhiyun struct metapage *smp;
1323*4882a593Smuzhiyun dtpage_t *sp;
1324*4882a593Smuzhiyun struct metapage *rmp;
1325*4882a593Smuzhiyun dtpage_t *rp; /* new right page allocated */
1326*4882a593Smuzhiyun s64 rbn; /* new right page block number */
1327*4882a593Smuzhiyun struct metapage *mp;
1328*4882a593Smuzhiyun dtpage_t *p;
1329*4882a593Smuzhiyun s64 nextbn;
1330*4882a593Smuzhiyun struct pxdlist *pxdlist;
1331*4882a593Smuzhiyun pxd_t *pxd;
1332*4882a593Smuzhiyun int skip, nextindex, half, left, nxt, off, si;
1333*4882a593Smuzhiyun struct ldtentry *ldtentry;
1334*4882a593Smuzhiyun struct idtentry *idtentry;
1335*4882a593Smuzhiyun u8 *stbl;
1336*4882a593Smuzhiyun struct dtslot *f;
1337*4882a593Smuzhiyun int fsi, stblsize;
1338*4882a593Smuzhiyun int n;
1339*4882a593Smuzhiyun struct dt_lock *sdtlck, *rdtlck;
1340*4882a593Smuzhiyun struct tlock *tlck;
1341*4882a593Smuzhiyun struct dt_lock *dtlck;
1342*4882a593Smuzhiyun struct lv *slv, *rlv, *lv;
1343*4882a593Smuzhiyun
1344*4882a593Smuzhiyun /* get split page */
1345*4882a593Smuzhiyun smp = split->mp;
1346*4882a593Smuzhiyun sp = DT_PAGE(ip, smp);
1347*4882a593Smuzhiyun
1348*4882a593Smuzhiyun /*
1349*4882a593Smuzhiyun * allocate the new right page for the split
1350*4882a593Smuzhiyun */
1351*4882a593Smuzhiyun pxdlist = split->pxdlist;
1352*4882a593Smuzhiyun pxd = &pxdlist->pxd[pxdlist->npxd];
1353*4882a593Smuzhiyun pxdlist->npxd++;
1354*4882a593Smuzhiyun rbn = addressPXD(pxd);
1355*4882a593Smuzhiyun rmp = get_metapage(ip, rbn, PSIZE, 1);
1356*4882a593Smuzhiyun if (rmp == NULL)
1357*4882a593Smuzhiyun return -EIO;
1358*4882a593Smuzhiyun
1359*4882a593Smuzhiyun /* Allocate blocks to quota. */
1360*4882a593Smuzhiyun rc = dquot_alloc_block(ip, lengthPXD(pxd));
1361*4882a593Smuzhiyun if (rc) {
1362*4882a593Smuzhiyun release_metapage(rmp);
1363*4882a593Smuzhiyun return rc;
1364*4882a593Smuzhiyun }
1365*4882a593Smuzhiyun
1366*4882a593Smuzhiyun jfs_info("dtSplitPage: ip:0x%p smp:0x%p rmp:0x%p", ip, smp, rmp);
1367*4882a593Smuzhiyun
1368*4882a593Smuzhiyun BT_MARK_DIRTY(rmp, ip);
1369*4882a593Smuzhiyun /*
1370*4882a593Smuzhiyun * acquire a transaction lock on the new right page
1371*4882a593Smuzhiyun */
1372*4882a593Smuzhiyun tlck = txLock(tid, ip, rmp, tlckDTREE | tlckNEW);
1373*4882a593Smuzhiyun rdtlck = (struct dt_lock *) & tlck->lock;
1374*4882a593Smuzhiyun
1375*4882a593Smuzhiyun rp = (dtpage_t *) rmp->data;
1376*4882a593Smuzhiyun *rpp = rp;
1377*4882a593Smuzhiyun rp->header.self = *pxd;
1378*4882a593Smuzhiyun
1379*4882a593Smuzhiyun BT_MARK_DIRTY(smp, ip);
1380*4882a593Smuzhiyun /*
1381*4882a593Smuzhiyun * acquire a transaction lock on the split page
1382*4882a593Smuzhiyun *
1383*4882a593Smuzhiyun * action:
1384*4882a593Smuzhiyun */
1385*4882a593Smuzhiyun tlck = txLock(tid, ip, smp, tlckDTREE | tlckENTRY);
1386*4882a593Smuzhiyun sdtlck = (struct dt_lock *) & tlck->lock;
1387*4882a593Smuzhiyun
1388*4882a593Smuzhiyun /* linelock header of split page */
1389*4882a593Smuzhiyun ASSERT(sdtlck->index == 0);
1390*4882a593Smuzhiyun slv = & sdtlck->lv[0];
1391*4882a593Smuzhiyun slv->offset = 0;
1392*4882a593Smuzhiyun slv->length = 1;
1393*4882a593Smuzhiyun sdtlck->index++;
1394*4882a593Smuzhiyun
1395*4882a593Smuzhiyun /*
1396*4882a593Smuzhiyun * initialize/update sibling pointers between sp and rp
1397*4882a593Smuzhiyun */
1398*4882a593Smuzhiyun nextbn = le64_to_cpu(sp->header.next);
1399*4882a593Smuzhiyun rp->header.next = cpu_to_le64(nextbn);
1400*4882a593Smuzhiyun rp->header.prev = cpu_to_le64(addressPXD(&sp->header.self));
1401*4882a593Smuzhiyun sp->header.next = cpu_to_le64(rbn);
1402*4882a593Smuzhiyun
1403*4882a593Smuzhiyun /*
1404*4882a593Smuzhiyun * initialize new right page
1405*4882a593Smuzhiyun */
1406*4882a593Smuzhiyun rp->header.flag = sp->header.flag;
1407*4882a593Smuzhiyun
1408*4882a593Smuzhiyun /* compute sorted entry table at start of extent data area */
1409*4882a593Smuzhiyun rp->header.nextindex = 0;
1410*4882a593Smuzhiyun rp->header.stblindex = 1;
1411*4882a593Smuzhiyun
1412*4882a593Smuzhiyun n = PSIZE >> L2DTSLOTSIZE;
1413*4882a593Smuzhiyun rp->header.maxslot = n;
1414*4882a593Smuzhiyun stblsize = (n + 31) >> L2DTSLOTSIZE; /* in unit of slot */
1415*4882a593Smuzhiyun
1416*4882a593Smuzhiyun /* init freelist */
1417*4882a593Smuzhiyun fsi = rp->header.stblindex + stblsize;
1418*4882a593Smuzhiyun rp->header.freelist = fsi;
1419*4882a593Smuzhiyun rp->header.freecnt = rp->header.maxslot - fsi;
1420*4882a593Smuzhiyun
1421*4882a593Smuzhiyun /*
1422*4882a593Smuzhiyun * sequential append at tail: append without split
1423*4882a593Smuzhiyun *
1424*4882a593Smuzhiyun * If splitting the last page on a level because of appending
1425*4882a593Smuzhiyun * a entry to it (skip is maxentry), it's likely that the access is
1426*4882a593Smuzhiyun * sequential. Adding an empty page on the side of the level is less
1427*4882a593Smuzhiyun * work and can push the fill factor much higher than normal.
1428*4882a593Smuzhiyun * If we're wrong it's no big deal, we'll just do the split the right
1429*4882a593Smuzhiyun * way next time.
1430*4882a593Smuzhiyun * (It may look like it's equally easy to do a similar hack for
1431*4882a593Smuzhiyun * reverse sorted data, that is, split the tree left,
1432*4882a593Smuzhiyun * but it's not. Be my guest.)
1433*4882a593Smuzhiyun */
1434*4882a593Smuzhiyun if (nextbn == 0 && split->index == sp->header.nextindex) {
1435*4882a593Smuzhiyun /* linelock header + stbl (first slot) of new page */
1436*4882a593Smuzhiyun rlv = & rdtlck->lv[rdtlck->index];
1437*4882a593Smuzhiyun rlv->offset = 0;
1438*4882a593Smuzhiyun rlv->length = 2;
1439*4882a593Smuzhiyun rdtlck->index++;
1440*4882a593Smuzhiyun
1441*4882a593Smuzhiyun /*
1442*4882a593Smuzhiyun * initialize freelist of new right page
1443*4882a593Smuzhiyun */
1444*4882a593Smuzhiyun f = &rp->slot[fsi];
1445*4882a593Smuzhiyun for (fsi++; fsi < rp->header.maxslot; f++, fsi++)
1446*4882a593Smuzhiyun f->next = fsi;
1447*4882a593Smuzhiyun f->next = -1;
1448*4882a593Smuzhiyun
1449*4882a593Smuzhiyun /* insert entry at the first entry of the new right page */
1450*4882a593Smuzhiyun dtInsertEntry(rp, 0, split->key, split->data, &rdtlck);
1451*4882a593Smuzhiyun
1452*4882a593Smuzhiyun goto out;
1453*4882a593Smuzhiyun }
1454*4882a593Smuzhiyun
1455*4882a593Smuzhiyun /*
1456*4882a593Smuzhiyun * non-sequential insert (at possibly middle page)
1457*4882a593Smuzhiyun */
1458*4882a593Smuzhiyun
1459*4882a593Smuzhiyun /*
1460*4882a593Smuzhiyun * update prev pointer of previous right sibling page;
1461*4882a593Smuzhiyun */
1462*4882a593Smuzhiyun if (nextbn != 0) {
1463*4882a593Smuzhiyun DT_GETPAGE(ip, nextbn, mp, PSIZE, p, rc);
1464*4882a593Smuzhiyun if (rc) {
1465*4882a593Smuzhiyun discard_metapage(rmp);
1466*4882a593Smuzhiyun return rc;
1467*4882a593Smuzhiyun }
1468*4882a593Smuzhiyun
1469*4882a593Smuzhiyun BT_MARK_DIRTY(mp, ip);
1470*4882a593Smuzhiyun /*
1471*4882a593Smuzhiyun * acquire a transaction lock on the next page
1472*4882a593Smuzhiyun */
1473*4882a593Smuzhiyun tlck = txLock(tid, ip, mp, tlckDTREE | tlckRELINK);
1474*4882a593Smuzhiyun jfs_info("dtSplitPage: tlck = 0x%p, ip = 0x%p, mp=0x%p",
1475*4882a593Smuzhiyun tlck, ip, mp);
1476*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
1477*4882a593Smuzhiyun
1478*4882a593Smuzhiyun /* linelock header of previous right sibling page */
1479*4882a593Smuzhiyun lv = & dtlck->lv[dtlck->index];
1480*4882a593Smuzhiyun lv->offset = 0;
1481*4882a593Smuzhiyun lv->length = 1;
1482*4882a593Smuzhiyun dtlck->index++;
1483*4882a593Smuzhiyun
1484*4882a593Smuzhiyun p->header.prev = cpu_to_le64(rbn);
1485*4882a593Smuzhiyun
1486*4882a593Smuzhiyun DT_PUTPAGE(mp);
1487*4882a593Smuzhiyun }
1488*4882a593Smuzhiyun
1489*4882a593Smuzhiyun /*
1490*4882a593Smuzhiyun * split the data between the split and right pages.
1491*4882a593Smuzhiyun */
1492*4882a593Smuzhiyun skip = split->index;
1493*4882a593Smuzhiyun half = (PSIZE >> L2DTSLOTSIZE) >> 1; /* swag */
1494*4882a593Smuzhiyun left = 0;
1495*4882a593Smuzhiyun
1496*4882a593Smuzhiyun /*
1497*4882a593Smuzhiyun * compute fill factor for split pages
1498*4882a593Smuzhiyun *
1499*4882a593Smuzhiyun * <nxt> traces the next entry to move to rp
1500*4882a593Smuzhiyun * <off> traces the next entry to stay in sp
1501*4882a593Smuzhiyun */
1502*4882a593Smuzhiyun stbl = (u8 *) & sp->slot[sp->header.stblindex];
1503*4882a593Smuzhiyun nextindex = sp->header.nextindex;
1504*4882a593Smuzhiyun for (nxt = off = 0; nxt < nextindex; ++off) {
1505*4882a593Smuzhiyun if (off == skip)
1506*4882a593Smuzhiyun /* check for fill factor with new entry size */
1507*4882a593Smuzhiyun n = split->nslot;
1508*4882a593Smuzhiyun else {
1509*4882a593Smuzhiyun si = stbl[nxt];
1510*4882a593Smuzhiyun switch (sp->header.flag & BT_TYPE) {
1511*4882a593Smuzhiyun case BT_LEAF:
1512*4882a593Smuzhiyun ldtentry = (struct ldtentry *) & sp->slot[si];
1513*4882a593Smuzhiyun if (DO_INDEX(ip))
1514*4882a593Smuzhiyun n = NDTLEAF(ldtentry->namlen);
1515*4882a593Smuzhiyun else
1516*4882a593Smuzhiyun n = NDTLEAF_LEGACY(ldtentry->
1517*4882a593Smuzhiyun namlen);
1518*4882a593Smuzhiyun break;
1519*4882a593Smuzhiyun
1520*4882a593Smuzhiyun case BT_INTERNAL:
1521*4882a593Smuzhiyun idtentry = (struct idtentry *) & sp->slot[si];
1522*4882a593Smuzhiyun n = NDTINTERNAL(idtentry->namlen);
1523*4882a593Smuzhiyun break;
1524*4882a593Smuzhiyun
1525*4882a593Smuzhiyun default:
1526*4882a593Smuzhiyun break;
1527*4882a593Smuzhiyun }
1528*4882a593Smuzhiyun
1529*4882a593Smuzhiyun ++nxt; /* advance to next entry to move in sp */
1530*4882a593Smuzhiyun }
1531*4882a593Smuzhiyun
1532*4882a593Smuzhiyun left += n;
1533*4882a593Smuzhiyun if (left >= half)
1534*4882a593Smuzhiyun break;
1535*4882a593Smuzhiyun }
1536*4882a593Smuzhiyun
1537*4882a593Smuzhiyun /* <nxt> poins to the 1st entry to move */
1538*4882a593Smuzhiyun
1539*4882a593Smuzhiyun /*
1540*4882a593Smuzhiyun * move entries to right page
1541*4882a593Smuzhiyun *
1542*4882a593Smuzhiyun * dtMoveEntry() initializes rp and reserves entry for insertion
1543*4882a593Smuzhiyun *
1544*4882a593Smuzhiyun * split page moved out entries are linelocked;
1545*4882a593Smuzhiyun * new/right page moved in entries are linelocked;
1546*4882a593Smuzhiyun */
1547*4882a593Smuzhiyun /* linelock header + stbl of new right page */
1548*4882a593Smuzhiyun rlv = & rdtlck->lv[rdtlck->index];
1549*4882a593Smuzhiyun rlv->offset = 0;
1550*4882a593Smuzhiyun rlv->length = 5;
1551*4882a593Smuzhiyun rdtlck->index++;
1552*4882a593Smuzhiyun
1553*4882a593Smuzhiyun dtMoveEntry(sp, nxt, rp, &sdtlck, &rdtlck, DO_INDEX(ip));
1554*4882a593Smuzhiyun
1555*4882a593Smuzhiyun sp->header.nextindex = nxt;
1556*4882a593Smuzhiyun
1557*4882a593Smuzhiyun /*
1558*4882a593Smuzhiyun * finalize freelist of new right page
1559*4882a593Smuzhiyun */
1560*4882a593Smuzhiyun fsi = rp->header.freelist;
1561*4882a593Smuzhiyun f = &rp->slot[fsi];
1562*4882a593Smuzhiyun for (fsi++; fsi < rp->header.maxslot; f++, fsi++)
1563*4882a593Smuzhiyun f->next = fsi;
1564*4882a593Smuzhiyun f->next = -1;
1565*4882a593Smuzhiyun
1566*4882a593Smuzhiyun /*
1567*4882a593Smuzhiyun * Update directory index table for entries now in right page
1568*4882a593Smuzhiyun */
1569*4882a593Smuzhiyun if ((rp->header.flag & BT_LEAF) && DO_INDEX(ip)) {
1570*4882a593Smuzhiyun s64 lblock;
1571*4882a593Smuzhiyun
1572*4882a593Smuzhiyun mp = NULL;
1573*4882a593Smuzhiyun stbl = DT_GETSTBL(rp);
1574*4882a593Smuzhiyun for (n = 0; n < rp->header.nextindex; n++) {
1575*4882a593Smuzhiyun ldtentry = (struct ldtentry *) & rp->slot[stbl[n]];
1576*4882a593Smuzhiyun modify_index(tid, ip, le32_to_cpu(ldtentry->index),
1577*4882a593Smuzhiyun rbn, n, &mp, &lblock);
1578*4882a593Smuzhiyun }
1579*4882a593Smuzhiyun if (mp)
1580*4882a593Smuzhiyun release_metapage(mp);
1581*4882a593Smuzhiyun }
1582*4882a593Smuzhiyun
1583*4882a593Smuzhiyun /*
1584*4882a593Smuzhiyun * the skipped index was on the left page,
1585*4882a593Smuzhiyun */
1586*4882a593Smuzhiyun if (skip <= off) {
1587*4882a593Smuzhiyun /* insert the new entry in the split page */
1588*4882a593Smuzhiyun dtInsertEntry(sp, skip, split->key, split->data, &sdtlck);
1589*4882a593Smuzhiyun
1590*4882a593Smuzhiyun /* linelock stbl of split page */
1591*4882a593Smuzhiyun if (sdtlck->index >= sdtlck->maxcnt)
1592*4882a593Smuzhiyun sdtlck = (struct dt_lock *) txLinelock(sdtlck);
1593*4882a593Smuzhiyun slv = & sdtlck->lv[sdtlck->index];
1594*4882a593Smuzhiyun n = skip >> L2DTSLOTSIZE;
1595*4882a593Smuzhiyun slv->offset = sp->header.stblindex + n;
1596*4882a593Smuzhiyun slv->length =
1597*4882a593Smuzhiyun ((sp->header.nextindex - 1) >> L2DTSLOTSIZE) - n + 1;
1598*4882a593Smuzhiyun sdtlck->index++;
1599*4882a593Smuzhiyun }
1600*4882a593Smuzhiyun /*
1601*4882a593Smuzhiyun * the skipped index was on the right page,
1602*4882a593Smuzhiyun */
1603*4882a593Smuzhiyun else {
1604*4882a593Smuzhiyun /* adjust the skip index to reflect the new position */
1605*4882a593Smuzhiyun skip -= nxt;
1606*4882a593Smuzhiyun
1607*4882a593Smuzhiyun /* insert the new entry in the right page */
1608*4882a593Smuzhiyun dtInsertEntry(rp, skip, split->key, split->data, &rdtlck);
1609*4882a593Smuzhiyun }
1610*4882a593Smuzhiyun
1611*4882a593Smuzhiyun out:
1612*4882a593Smuzhiyun *rmpp = rmp;
1613*4882a593Smuzhiyun *rpxdp = *pxd;
1614*4882a593Smuzhiyun
1615*4882a593Smuzhiyun return rc;
1616*4882a593Smuzhiyun }
1617*4882a593Smuzhiyun
1618*4882a593Smuzhiyun
1619*4882a593Smuzhiyun /*
1620*4882a593Smuzhiyun * dtExtendPage()
1621*4882a593Smuzhiyun *
1622*4882a593Smuzhiyun * function: extend 1st/only directory leaf page
1623*4882a593Smuzhiyun *
1624*4882a593Smuzhiyun * parameter:
1625*4882a593Smuzhiyun *
1626*4882a593Smuzhiyun * return: 0 - success;
1627*4882a593Smuzhiyun * errno - failure;
1628*4882a593Smuzhiyun * return extended page pinned;
1629*4882a593Smuzhiyun */
dtExtendPage(tid_t tid,struct inode * ip,struct dtsplit * split,struct btstack * btstack)1630*4882a593Smuzhiyun static int dtExtendPage(tid_t tid,
1631*4882a593Smuzhiyun struct inode *ip, struct dtsplit * split, struct btstack * btstack)
1632*4882a593Smuzhiyun {
1633*4882a593Smuzhiyun struct super_block *sb = ip->i_sb;
1634*4882a593Smuzhiyun int rc;
1635*4882a593Smuzhiyun struct metapage *smp, *pmp, *mp;
1636*4882a593Smuzhiyun dtpage_t *sp, *pp;
1637*4882a593Smuzhiyun struct pxdlist *pxdlist;
1638*4882a593Smuzhiyun pxd_t *pxd, *tpxd;
1639*4882a593Smuzhiyun int xlen, xsize;
1640*4882a593Smuzhiyun int newstblindex, newstblsize;
1641*4882a593Smuzhiyun int oldstblindex, oldstblsize;
1642*4882a593Smuzhiyun int fsi, last;
1643*4882a593Smuzhiyun struct dtslot *f;
1644*4882a593Smuzhiyun struct btframe *parent;
1645*4882a593Smuzhiyun int n;
1646*4882a593Smuzhiyun struct dt_lock *dtlck;
1647*4882a593Smuzhiyun s64 xaddr, txaddr;
1648*4882a593Smuzhiyun struct tlock *tlck;
1649*4882a593Smuzhiyun struct pxd_lock *pxdlock;
1650*4882a593Smuzhiyun struct lv *lv;
1651*4882a593Smuzhiyun uint type;
1652*4882a593Smuzhiyun struct ldtentry *ldtentry;
1653*4882a593Smuzhiyun u8 *stbl;
1654*4882a593Smuzhiyun
1655*4882a593Smuzhiyun /* get page to extend */
1656*4882a593Smuzhiyun smp = split->mp;
1657*4882a593Smuzhiyun sp = DT_PAGE(ip, smp);
1658*4882a593Smuzhiyun
1659*4882a593Smuzhiyun /* get parent/root page */
1660*4882a593Smuzhiyun parent = BT_POP(btstack);
1661*4882a593Smuzhiyun DT_GETPAGE(ip, parent->bn, pmp, PSIZE, pp, rc);
1662*4882a593Smuzhiyun if (rc)
1663*4882a593Smuzhiyun return (rc);
1664*4882a593Smuzhiyun
1665*4882a593Smuzhiyun /*
1666*4882a593Smuzhiyun * extend the extent
1667*4882a593Smuzhiyun */
1668*4882a593Smuzhiyun pxdlist = split->pxdlist;
1669*4882a593Smuzhiyun pxd = &pxdlist->pxd[pxdlist->npxd];
1670*4882a593Smuzhiyun pxdlist->npxd++;
1671*4882a593Smuzhiyun
1672*4882a593Smuzhiyun xaddr = addressPXD(pxd);
1673*4882a593Smuzhiyun tpxd = &sp->header.self;
1674*4882a593Smuzhiyun txaddr = addressPXD(tpxd);
1675*4882a593Smuzhiyun /* in-place extension */
1676*4882a593Smuzhiyun if (xaddr == txaddr) {
1677*4882a593Smuzhiyun type = tlckEXTEND;
1678*4882a593Smuzhiyun }
1679*4882a593Smuzhiyun /* relocation */
1680*4882a593Smuzhiyun else {
1681*4882a593Smuzhiyun type = tlckNEW;
1682*4882a593Smuzhiyun
1683*4882a593Smuzhiyun /* save moved extent descriptor for later free */
1684*4882a593Smuzhiyun tlck = txMaplock(tid, ip, tlckDTREE | tlckRELOCATE);
1685*4882a593Smuzhiyun pxdlock = (struct pxd_lock *) & tlck->lock;
1686*4882a593Smuzhiyun pxdlock->flag = mlckFREEPXD;
1687*4882a593Smuzhiyun pxdlock->pxd = sp->header.self;
1688*4882a593Smuzhiyun pxdlock->index = 1;
1689*4882a593Smuzhiyun
1690*4882a593Smuzhiyun /*
1691*4882a593Smuzhiyun * Update directory index table to reflect new page address
1692*4882a593Smuzhiyun */
1693*4882a593Smuzhiyun if (DO_INDEX(ip)) {
1694*4882a593Smuzhiyun s64 lblock;
1695*4882a593Smuzhiyun
1696*4882a593Smuzhiyun mp = NULL;
1697*4882a593Smuzhiyun stbl = DT_GETSTBL(sp);
1698*4882a593Smuzhiyun for (n = 0; n < sp->header.nextindex; n++) {
1699*4882a593Smuzhiyun ldtentry =
1700*4882a593Smuzhiyun (struct ldtentry *) & sp->slot[stbl[n]];
1701*4882a593Smuzhiyun modify_index(tid, ip,
1702*4882a593Smuzhiyun le32_to_cpu(ldtentry->index),
1703*4882a593Smuzhiyun xaddr, n, &mp, &lblock);
1704*4882a593Smuzhiyun }
1705*4882a593Smuzhiyun if (mp)
1706*4882a593Smuzhiyun release_metapage(mp);
1707*4882a593Smuzhiyun }
1708*4882a593Smuzhiyun }
1709*4882a593Smuzhiyun
1710*4882a593Smuzhiyun /*
1711*4882a593Smuzhiyun * extend the page
1712*4882a593Smuzhiyun */
1713*4882a593Smuzhiyun sp->header.self = *pxd;
1714*4882a593Smuzhiyun
1715*4882a593Smuzhiyun jfs_info("dtExtendPage: ip:0x%p smp:0x%p sp:0x%p", ip, smp, sp);
1716*4882a593Smuzhiyun
1717*4882a593Smuzhiyun BT_MARK_DIRTY(smp, ip);
1718*4882a593Smuzhiyun /*
1719*4882a593Smuzhiyun * acquire a transaction lock on the extended/leaf page
1720*4882a593Smuzhiyun */
1721*4882a593Smuzhiyun tlck = txLock(tid, ip, smp, tlckDTREE | type);
1722*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
1723*4882a593Smuzhiyun lv = & dtlck->lv[0];
1724*4882a593Smuzhiyun
1725*4882a593Smuzhiyun /* update buffer extent descriptor of extended page */
1726*4882a593Smuzhiyun xlen = lengthPXD(pxd);
1727*4882a593Smuzhiyun xsize = xlen << JFS_SBI(sb)->l2bsize;
1728*4882a593Smuzhiyun
1729*4882a593Smuzhiyun /*
1730*4882a593Smuzhiyun * copy old stbl to new stbl at start of extended area
1731*4882a593Smuzhiyun */
1732*4882a593Smuzhiyun oldstblindex = sp->header.stblindex;
1733*4882a593Smuzhiyun oldstblsize = (sp->header.maxslot + 31) >> L2DTSLOTSIZE;
1734*4882a593Smuzhiyun newstblindex = sp->header.maxslot;
1735*4882a593Smuzhiyun n = xsize >> L2DTSLOTSIZE;
1736*4882a593Smuzhiyun newstblsize = (n + 31) >> L2DTSLOTSIZE;
1737*4882a593Smuzhiyun memcpy(&sp->slot[newstblindex], &sp->slot[oldstblindex],
1738*4882a593Smuzhiyun sp->header.nextindex);
1739*4882a593Smuzhiyun
1740*4882a593Smuzhiyun /*
1741*4882a593Smuzhiyun * in-line extension: linelock old area of extended page
1742*4882a593Smuzhiyun */
1743*4882a593Smuzhiyun if (type == tlckEXTEND) {
1744*4882a593Smuzhiyun /* linelock header */
1745*4882a593Smuzhiyun lv->offset = 0;
1746*4882a593Smuzhiyun lv->length = 1;
1747*4882a593Smuzhiyun dtlck->index++;
1748*4882a593Smuzhiyun lv++;
1749*4882a593Smuzhiyun
1750*4882a593Smuzhiyun /* linelock new stbl of extended page */
1751*4882a593Smuzhiyun lv->offset = newstblindex;
1752*4882a593Smuzhiyun lv->length = newstblsize;
1753*4882a593Smuzhiyun }
1754*4882a593Smuzhiyun /*
1755*4882a593Smuzhiyun * relocation: linelock whole relocated area
1756*4882a593Smuzhiyun */
1757*4882a593Smuzhiyun else {
1758*4882a593Smuzhiyun lv->offset = 0;
1759*4882a593Smuzhiyun lv->length = sp->header.maxslot + newstblsize;
1760*4882a593Smuzhiyun }
1761*4882a593Smuzhiyun
1762*4882a593Smuzhiyun dtlck->index++;
1763*4882a593Smuzhiyun
1764*4882a593Smuzhiyun sp->header.maxslot = n;
1765*4882a593Smuzhiyun sp->header.stblindex = newstblindex;
1766*4882a593Smuzhiyun /* sp->header.nextindex remains the same */
1767*4882a593Smuzhiyun
1768*4882a593Smuzhiyun /*
1769*4882a593Smuzhiyun * add old stbl region at head of freelist
1770*4882a593Smuzhiyun */
1771*4882a593Smuzhiyun fsi = oldstblindex;
1772*4882a593Smuzhiyun f = &sp->slot[fsi];
1773*4882a593Smuzhiyun last = sp->header.freelist;
1774*4882a593Smuzhiyun for (n = 0; n < oldstblsize; n++, fsi++, f++) {
1775*4882a593Smuzhiyun f->next = last;
1776*4882a593Smuzhiyun last = fsi;
1777*4882a593Smuzhiyun }
1778*4882a593Smuzhiyun sp->header.freelist = last;
1779*4882a593Smuzhiyun sp->header.freecnt += oldstblsize;
1780*4882a593Smuzhiyun
1781*4882a593Smuzhiyun /*
1782*4882a593Smuzhiyun * append free region of newly extended area at tail of freelist
1783*4882a593Smuzhiyun */
1784*4882a593Smuzhiyun /* init free region of newly extended area */
1785*4882a593Smuzhiyun fsi = n = newstblindex + newstblsize;
1786*4882a593Smuzhiyun f = &sp->slot[fsi];
1787*4882a593Smuzhiyun for (fsi++; fsi < sp->header.maxslot; f++, fsi++)
1788*4882a593Smuzhiyun f->next = fsi;
1789*4882a593Smuzhiyun f->next = -1;
1790*4882a593Smuzhiyun
1791*4882a593Smuzhiyun /* append new free region at tail of old freelist */
1792*4882a593Smuzhiyun fsi = sp->header.freelist;
1793*4882a593Smuzhiyun if (fsi == -1)
1794*4882a593Smuzhiyun sp->header.freelist = n;
1795*4882a593Smuzhiyun else {
1796*4882a593Smuzhiyun do {
1797*4882a593Smuzhiyun f = &sp->slot[fsi];
1798*4882a593Smuzhiyun fsi = f->next;
1799*4882a593Smuzhiyun } while (fsi != -1);
1800*4882a593Smuzhiyun
1801*4882a593Smuzhiyun f->next = n;
1802*4882a593Smuzhiyun }
1803*4882a593Smuzhiyun
1804*4882a593Smuzhiyun sp->header.freecnt += sp->header.maxslot - n;
1805*4882a593Smuzhiyun
1806*4882a593Smuzhiyun /*
1807*4882a593Smuzhiyun * insert the new entry
1808*4882a593Smuzhiyun */
1809*4882a593Smuzhiyun dtInsertEntry(sp, split->index, split->key, split->data, &dtlck);
1810*4882a593Smuzhiyun
1811*4882a593Smuzhiyun BT_MARK_DIRTY(pmp, ip);
1812*4882a593Smuzhiyun /*
1813*4882a593Smuzhiyun * linelock any freeslots residing in old extent
1814*4882a593Smuzhiyun */
1815*4882a593Smuzhiyun if (type == tlckEXTEND) {
1816*4882a593Smuzhiyun n = sp->header.maxslot >> 2;
1817*4882a593Smuzhiyun if (sp->header.freelist < n)
1818*4882a593Smuzhiyun dtLinelockFreelist(sp, n, &dtlck);
1819*4882a593Smuzhiyun }
1820*4882a593Smuzhiyun
1821*4882a593Smuzhiyun /*
1822*4882a593Smuzhiyun * update parent entry on the parent/root page
1823*4882a593Smuzhiyun */
1824*4882a593Smuzhiyun /*
1825*4882a593Smuzhiyun * acquire a transaction lock on the parent/root page
1826*4882a593Smuzhiyun */
1827*4882a593Smuzhiyun tlck = txLock(tid, ip, pmp, tlckDTREE | tlckENTRY);
1828*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
1829*4882a593Smuzhiyun lv = & dtlck->lv[dtlck->index];
1830*4882a593Smuzhiyun
1831*4882a593Smuzhiyun /* linelock parent entry - 1st slot */
1832*4882a593Smuzhiyun lv->offset = 1;
1833*4882a593Smuzhiyun lv->length = 1;
1834*4882a593Smuzhiyun dtlck->index++;
1835*4882a593Smuzhiyun
1836*4882a593Smuzhiyun /* update the parent pxd for page extension */
1837*4882a593Smuzhiyun tpxd = (pxd_t *) & pp->slot[1];
1838*4882a593Smuzhiyun *tpxd = *pxd;
1839*4882a593Smuzhiyun
1840*4882a593Smuzhiyun DT_PUTPAGE(pmp);
1841*4882a593Smuzhiyun return 0;
1842*4882a593Smuzhiyun }
1843*4882a593Smuzhiyun
1844*4882a593Smuzhiyun
1845*4882a593Smuzhiyun /*
1846*4882a593Smuzhiyun * dtSplitRoot()
1847*4882a593Smuzhiyun *
1848*4882a593Smuzhiyun * function:
1849*4882a593Smuzhiyun * split the full root page into
1850*4882a593Smuzhiyun * original/root/split page and new right page
1851*4882a593Smuzhiyun * i.e., root remains fixed in tree anchor (inode) and
1852*4882a593Smuzhiyun * the root is copied to a single new right child page
1853*4882a593Smuzhiyun * since root page << non-root page, and
1854*4882a593Smuzhiyun * the split root page contains a single entry for the
1855*4882a593Smuzhiyun * new right child page.
1856*4882a593Smuzhiyun *
1857*4882a593Smuzhiyun * parameter:
1858*4882a593Smuzhiyun *
1859*4882a593Smuzhiyun * return: 0 - success;
1860*4882a593Smuzhiyun * errno - failure;
1861*4882a593Smuzhiyun * return new page pinned;
1862*4882a593Smuzhiyun */
dtSplitRoot(tid_t tid,struct inode * ip,struct dtsplit * split,struct metapage ** rmpp)1863*4882a593Smuzhiyun static int dtSplitRoot(tid_t tid,
1864*4882a593Smuzhiyun struct inode *ip, struct dtsplit * split, struct metapage ** rmpp)
1865*4882a593Smuzhiyun {
1866*4882a593Smuzhiyun struct super_block *sb = ip->i_sb;
1867*4882a593Smuzhiyun struct metapage *smp;
1868*4882a593Smuzhiyun dtroot_t *sp;
1869*4882a593Smuzhiyun struct metapage *rmp;
1870*4882a593Smuzhiyun dtpage_t *rp;
1871*4882a593Smuzhiyun s64 rbn;
1872*4882a593Smuzhiyun int xlen;
1873*4882a593Smuzhiyun int xsize;
1874*4882a593Smuzhiyun struct dtslot *f;
1875*4882a593Smuzhiyun s8 *stbl;
1876*4882a593Smuzhiyun int fsi, stblsize, n;
1877*4882a593Smuzhiyun struct idtentry *s;
1878*4882a593Smuzhiyun pxd_t *ppxd;
1879*4882a593Smuzhiyun struct pxdlist *pxdlist;
1880*4882a593Smuzhiyun pxd_t *pxd;
1881*4882a593Smuzhiyun struct dt_lock *dtlck;
1882*4882a593Smuzhiyun struct tlock *tlck;
1883*4882a593Smuzhiyun struct lv *lv;
1884*4882a593Smuzhiyun int rc;
1885*4882a593Smuzhiyun
1886*4882a593Smuzhiyun /* get split root page */
1887*4882a593Smuzhiyun smp = split->mp;
1888*4882a593Smuzhiyun sp = &JFS_IP(ip)->i_dtroot;
1889*4882a593Smuzhiyun
1890*4882a593Smuzhiyun /*
1891*4882a593Smuzhiyun * allocate/initialize a single (right) child page
1892*4882a593Smuzhiyun *
1893*4882a593Smuzhiyun * N.B. at first split, a one (or two) block to fit new entry
1894*4882a593Smuzhiyun * is allocated; at subsequent split, a full page is allocated;
1895*4882a593Smuzhiyun */
1896*4882a593Smuzhiyun pxdlist = split->pxdlist;
1897*4882a593Smuzhiyun pxd = &pxdlist->pxd[pxdlist->npxd];
1898*4882a593Smuzhiyun pxdlist->npxd++;
1899*4882a593Smuzhiyun rbn = addressPXD(pxd);
1900*4882a593Smuzhiyun xlen = lengthPXD(pxd);
1901*4882a593Smuzhiyun xsize = xlen << JFS_SBI(sb)->l2bsize;
1902*4882a593Smuzhiyun rmp = get_metapage(ip, rbn, xsize, 1);
1903*4882a593Smuzhiyun if (!rmp)
1904*4882a593Smuzhiyun return -EIO;
1905*4882a593Smuzhiyun
1906*4882a593Smuzhiyun rp = rmp->data;
1907*4882a593Smuzhiyun
1908*4882a593Smuzhiyun /* Allocate blocks to quota. */
1909*4882a593Smuzhiyun rc = dquot_alloc_block(ip, lengthPXD(pxd));
1910*4882a593Smuzhiyun if (rc) {
1911*4882a593Smuzhiyun release_metapage(rmp);
1912*4882a593Smuzhiyun return rc;
1913*4882a593Smuzhiyun }
1914*4882a593Smuzhiyun
1915*4882a593Smuzhiyun BT_MARK_DIRTY(rmp, ip);
1916*4882a593Smuzhiyun /*
1917*4882a593Smuzhiyun * acquire a transaction lock on the new right page
1918*4882a593Smuzhiyun */
1919*4882a593Smuzhiyun tlck = txLock(tid, ip, rmp, tlckDTREE | tlckNEW);
1920*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
1921*4882a593Smuzhiyun
1922*4882a593Smuzhiyun rp->header.flag =
1923*4882a593Smuzhiyun (sp->header.flag & BT_LEAF) ? BT_LEAF : BT_INTERNAL;
1924*4882a593Smuzhiyun rp->header.self = *pxd;
1925*4882a593Smuzhiyun
1926*4882a593Smuzhiyun /* initialize sibling pointers */
1927*4882a593Smuzhiyun rp->header.next = 0;
1928*4882a593Smuzhiyun rp->header.prev = 0;
1929*4882a593Smuzhiyun
1930*4882a593Smuzhiyun /*
1931*4882a593Smuzhiyun * move in-line root page into new right page extent
1932*4882a593Smuzhiyun */
1933*4882a593Smuzhiyun /* linelock header + copied entries + new stbl (1st slot) in new page */
1934*4882a593Smuzhiyun ASSERT(dtlck->index == 0);
1935*4882a593Smuzhiyun lv = & dtlck->lv[0];
1936*4882a593Smuzhiyun lv->offset = 0;
1937*4882a593Smuzhiyun lv->length = 10; /* 1 + 8 + 1 */
1938*4882a593Smuzhiyun dtlck->index++;
1939*4882a593Smuzhiyun
1940*4882a593Smuzhiyun n = xsize >> L2DTSLOTSIZE;
1941*4882a593Smuzhiyun rp->header.maxslot = n;
1942*4882a593Smuzhiyun stblsize = (n + 31) >> L2DTSLOTSIZE;
1943*4882a593Smuzhiyun
1944*4882a593Smuzhiyun /* copy old stbl to new stbl at start of extended area */
1945*4882a593Smuzhiyun rp->header.stblindex = DTROOTMAXSLOT;
1946*4882a593Smuzhiyun stbl = (s8 *) & rp->slot[DTROOTMAXSLOT];
1947*4882a593Smuzhiyun memcpy(stbl, sp->header.stbl, sp->header.nextindex);
1948*4882a593Smuzhiyun rp->header.nextindex = sp->header.nextindex;
1949*4882a593Smuzhiyun
1950*4882a593Smuzhiyun /* copy old data area to start of new data area */
1951*4882a593Smuzhiyun memcpy(&rp->slot[1], &sp->slot[1], IDATASIZE);
1952*4882a593Smuzhiyun
1953*4882a593Smuzhiyun /*
1954*4882a593Smuzhiyun * append free region of newly extended area at tail of freelist
1955*4882a593Smuzhiyun */
1956*4882a593Smuzhiyun /* init free region of newly extended area */
1957*4882a593Smuzhiyun fsi = n = DTROOTMAXSLOT + stblsize;
1958*4882a593Smuzhiyun f = &rp->slot[fsi];
1959*4882a593Smuzhiyun for (fsi++; fsi < rp->header.maxslot; f++, fsi++)
1960*4882a593Smuzhiyun f->next = fsi;
1961*4882a593Smuzhiyun f->next = -1;
1962*4882a593Smuzhiyun
1963*4882a593Smuzhiyun /* append new free region at tail of old freelist */
1964*4882a593Smuzhiyun fsi = sp->header.freelist;
1965*4882a593Smuzhiyun if (fsi == -1)
1966*4882a593Smuzhiyun rp->header.freelist = n;
1967*4882a593Smuzhiyun else {
1968*4882a593Smuzhiyun rp->header.freelist = fsi;
1969*4882a593Smuzhiyun
1970*4882a593Smuzhiyun do {
1971*4882a593Smuzhiyun f = &rp->slot[fsi];
1972*4882a593Smuzhiyun fsi = f->next;
1973*4882a593Smuzhiyun } while (fsi != -1);
1974*4882a593Smuzhiyun
1975*4882a593Smuzhiyun f->next = n;
1976*4882a593Smuzhiyun }
1977*4882a593Smuzhiyun
1978*4882a593Smuzhiyun rp->header.freecnt = sp->header.freecnt + rp->header.maxslot - n;
1979*4882a593Smuzhiyun
1980*4882a593Smuzhiyun /*
1981*4882a593Smuzhiyun * Update directory index table for entries now in right page
1982*4882a593Smuzhiyun */
1983*4882a593Smuzhiyun if ((rp->header.flag & BT_LEAF) && DO_INDEX(ip)) {
1984*4882a593Smuzhiyun s64 lblock;
1985*4882a593Smuzhiyun struct metapage *mp = NULL;
1986*4882a593Smuzhiyun struct ldtentry *ldtentry;
1987*4882a593Smuzhiyun
1988*4882a593Smuzhiyun stbl = DT_GETSTBL(rp);
1989*4882a593Smuzhiyun for (n = 0; n < rp->header.nextindex; n++) {
1990*4882a593Smuzhiyun ldtentry = (struct ldtentry *) & rp->slot[stbl[n]];
1991*4882a593Smuzhiyun modify_index(tid, ip, le32_to_cpu(ldtentry->index),
1992*4882a593Smuzhiyun rbn, n, &mp, &lblock);
1993*4882a593Smuzhiyun }
1994*4882a593Smuzhiyun if (mp)
1995*4882a593Smuzhiyun release_metapage(mp);
1996*4882a593Smuzhiyun }
1997*4882a593Smuzhiyun /*
1998*4882a593Smuzhiyun * insert the new entry into the new right/child page
1999*4882a593Smuzhiyun * (skip index in the new right page will not change)
2000*4882a593Smuzhiyun */
2001*4882a593Smuzhiyun dtInsertEntry(rp, split->index, split->key, split->data, &dtlck);
2002*4882a593Smuzhiyun
2003*4882a593Smuzhiyun /*
2004*4882a593Smuzhiyun * reset parent/root page
2005*4882a593Smuzhiyun *
2006*4882a593Smuzhiyun * set the 1st entry offset to 0, which force the left-most key
2007*4882a593Smuzhiyun * at any level of the tree to be less than any search key.
2008*4882a593Smuzhiyun *
2009*4882a593Smuzhiyun * The btree comparison code guarantees that the left-most key on any
2010*4882a593Smuzhiyun * level of the tree is never used, so it doesn't need to be filled in.
2011*4882a593Smuzhiyun */
2012*4882a593Smuzhiyun BT_MARK_DIRTY(smp, ip);
2013*4882a593Smuzhiyun /*
2014*4882a593Smuzhiyun * acquire a transaction lock on the root page (in-memory inode)
2015*4882a593Smuzhiyun */
2016*4882a593Smuzhiyun tlck = txLock(tid, ip, smp, tlckDTREE | tlckNEW | tlckBTROOT);
2017*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
2018*4882a593Smuzhiyun
2019*4882a593Smuzhiyun /* linelock root */
2020*4882a593Smuzhiyun ASSERT(dtlck->index == 0);
2021*4882a593Smuzhiyun lv = & dtlck->lv[0];
2022*4882a593Smuzhiyun lv->offset = 0;
2023*4882a593Smuzhiyun lv->length = DTROOTMAXSLOT;
2024*4882a593Smuzhiyun dtlck->index++;
2025*4882a593Smuzhiyun
2026*4882a593Smuzhiyun /* update page header of root */
2027*4882a593Smuzhiyun if (sp->header.flag & BT_LEAF) {
2028*4882a593Smuzhiyun sp->header.flag &= ~BT_LEAF;
2029*4882a593Smuzhiyun sp->header.flag |= BT_INTERNAL;
2030*4882a593Smuzhiyun }
2031*4882a593Smuzhiyun
2032*4882a593Smuzhiyun /* init the first entry */
2033*4882a593Smuzhiyun s = (struct idtentry *) & sp->slot[DTENTRYSTART];
2034*4882a593Smuzhiyun ppxd = (pxd_t *) s;
2035*4882a593Smuzhiyun *ppxd = *pxd;
2036*4882a593Smuzhiyun s->next = -1;
2037*4882a593Smuzhiyun s->namlen = 0;
2038*4882a593Smuzhiyun
2039*4882a593Smuzhiyun stbl = sp->header.stbl;
2040*4882a593Smuzhiyun stbl[0] = DTENTRYSTART;
2041*4882a593Smuzhiyun sp->header.nextindex = 1;
2042*4882a593Smuzhiyun
2043*4882a593Smuzhiyun /* init freelist */
2044*4882a593Smuzhiyun fsi = DTENTRYSTART + 1;
2045*4882a593Smuzhiyun f = &sp->slot[fsi];
2046*4882a593Smuzhiyun
2047*4882a593Smuzhiyun /* init free region of remaining area */
2048*4882a593Smuzhiyun for (fsi++; fsi < DTROOTMAXSLOT; f++, fsi++)
2049*4882a593Smuzhiyun f->next = fsi;
2050*4882a593Smuzhiyun f->next = -1;
2051*4882a593Smuzhiyun
2052*4882a593Smuzhiyun sp->header.freelist = DTENTRYSTART + 1;
2053*4882a593Smuzhiyun sp->header.freecnt = DTROOTMAXSLOT - (DTENTRYSTART + 1);
2054*4882a593Smuzhiyun
2055*4882a593Smuzhiyun *rmpp = rmp;
2056*4882a593Smuzhiyun
2057*4882a593Smuzhiyun return 0;
2058*4882a593Smuzhiyun }
2059*4882a593Smuzhiyun
2060*4882a593Smuzhiyun
2061*4882a593Smuzhiyun /*
2062*4882a593Smuzhiyun * dtDelete()
2063*4882a593Smuzhiyun *
2064*4882a593Smuzhiyun * function: delete the entry(s) referenced by a key.
2065*4882a593Smuzhiyun *
2066*4882a593Smuzhiyun * parameter:
2067*4882a593Smuzhiyun *
2068*4882a593Smuzhiyun * return:
2069*4882a593Smuzhiyun */
dtDelete(tid_t tid,struct inode * ip,struct component_name * key,ino_t * ino,int flag)2070*4882a593Smuzhiyun int dtDelete(tid_t tid,
2071*4882a593Smuzhiyun struct inode *ip, struct component_name * key, ino_t * ino, int flag)
2072*4882a593Smuzhiyun {
2073*4882a593Smuzhiyun int rc = 0;
2074*4882a593Smuzhiyun s64 bn;
2075*4882a593Smuzhiyun struct metapage *mp, *imp;
2076*4882a593Smuzhiyun dtpage_t *p;
2077*4882a593Smuzhiyun int index;
2078*4882a593Smuzhiyun struct btstack btstack;
2079*4882a593Smuzhiyun struct dt_lock *dtlck;
2080*4882a593Smuzhiyun struct tlock *tlck;
2081*4882a593Smuzhiyun struct lv *lv;
2082*4882a593Smuzhiyun int i;
2083*4882a593Smuzhiyun struct ldtentry *ldtentry;
2084*4882a593Smuzhiyun u8 *stbl;
2085*4882a593Smuzhiyun u32 table_index, next_index;
2086*4882a593Smuzhiyun struct metapage *nmp;
2087*4882a593Smuzhiyun dtpage_t *np;
2088*4882a593Smuzhiyun
2089*4882a593Smuzhiyun /*
2090*4882a593Smuzhiyun * search for the entry to delete:
2091*4882a593Smuzhiyun *
2092*4882a593Smuzhiyun * dtSearch() returns (leaf page pinned, index at which to delete).
2093*4882a593Smuzhiyun */
2094*4882a593Smuzhiyun if ((rc = dtSearch(ip, key, ino, &btstack, flag)))
2095*4882a593Smuzhiyun return rc;
2096*4882a593Smuzhiyun
2097*4882a593Smuzhiyun /* retrieve search result */
2098*4882a593Smuzhiyun DT_GETSEARCH(ip, btstack.top, bn, mp, p, index);
2099*4882a593Smuzhiyun
2100*4882a593Smuzhiyun /*
2101*4882a593Smuzhiyun * We need to find put the index of the next entry into the
2102*4882a593Smuzhiyun * directory index table in order to resume a readdir from this
2103*4882a593Smuzhiyun * entry.
2104*4882a593Smuzhiyun */
2105*4882a593Smuzhiyun if (DO_INDEX(ip)) {
2106*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
2107*4882a593Smuzhiyun ldtentry = (struct ldtentry *) & p->slot[stbl[index]];
2108*4882a593Smuzhiyun table_index = le32_to_cpu(ldtentry->index);
2109*4882a593Smuzhiyun if (index == (p->header.nextindex - 1)) {
2110*4882a593Smuzhiyun /*
2111*4882a593Smuzhiyun * Last entry in this leaf page
2112*4882a593Smuzhiyun */
2113*4882a593Smuzhiyun if ((p->header.flag & BT_ROOT)
2114*4882a593Smuzhiyun || (p->header.next == 0))
2115*4882a593Smuzhiyun next_index = -1;
2116*4882a593Smuzhiyun else {
2117*4882a593Smuzhiyun /* Read next leaf page */
2118*4882a593Smuzhiyun DT_GETPAGE(ip, le64_to_cpu(p->header.next),
2119*4882a593Smuzhiyun nmp, PSIZE, np, rc);
2120*4882a593Smuzhiyun if (rc)
2121*4882a593Smuzhiyun next_index = -1;
2122*4882a593Smuzhiyun else {
2123*4882a593Smuzhiyun stbl = DT_GETSTBL(np);
2124*4882a593Smuzhiyun ldtentry =
2125*4882a593Smuzhiyun (struct ldtentry *) & np->
2126*4882a593Smuzhiyun slot[stbl[0]];
2127*4882a593Smuzhiyun next_index =
2128*4882a593Smuzhiyun le32_to_cpu(ldtentry->index);
2129*4882a593Smuzhiyun DT_PUTPAGE(nmp);
2130*4882a593Smuzhiyun }
2131*4882a593Smuzhiyun }
2132*4882a593Smuzhiyun } else {
2133*4882a593Smuzhiyun ldtentry =
2134*4882a593Smuzhiyun (struct ldtentry *) & p->slot[stbl[index + 1]];
2135*4882a593Smuzhiyun next_index = le32_to_cpu(ldtentry->index);
2136*4882a593Smuzhiyun }
2137*4882a593Smuzhiyun free_index(tid, ip, table_index, next_index);
2138*4882a593Smuzhiyun }
2139*4882a593Smuzhiyun /*
2140*4882a593Smuzhiyun * the leaf page becomes empty, delete the page
2141*4882a593Smuzhiyun */
2142*4882a593Smuzhiyun if (p->header.nextindex == 1) {
2143*4882a593Smuzhiyun /* delete empty page */
2144*4882a593Smuzhiyun rc = dtDeleteUp(tid, ip, mp, p, &btstack);
2145*4882a593Smuzhiyun }
2146*4882a593Smuzhiyun /*
2147*4882a593Smuzhiyun * the leaf page has other entries remaining:
2148*4882a593Smuzhiyun *
2149*4882a593Smuzhiyun * delete the entry from the leaf page.
2150*4882a593Smuzhiyun */
2151*4882a593Smuzhiyun else {
2152*4882a593Smuzhiyun BT_MARK_DIRTY(mp, ip);
2153*4882a593Smuzhiyun /*
2154*4882a593Smuzhiyun * acquire a transaction lock on the leaf page
2155*4882a593Smuzhiyun */
2156*4882a593Smuzhiyun tlck = txLock(tid, ip, mp, tlckDTREE | tlckENTRY);
2157*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
2158*4882a593Smuzhiyun
2159*4882a593Smuzhiyun /*
2160*4882a593Smuzhiyun * Do not assume that dtlck->index will be zero. During a
2161*4882a593Smuzhiyun * rename within a directory, this transaction may have
2162*4882a593Smuzhiyun * modified this page already when adding the new entry.
2163*4882a593Smuzhiyun */
2164*4882a593Smuzhiyun
2165*4882a593Smuzhiyun /* linelock header */
2166*4882a593Smuzhiyun if (dtlck->index >= dtlck->maxcnt)
2167*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
2168*4882a593Smuzhiyun lv = & dtlck->lv[dtlck->index];
2169*4882a593Smuzhiyun lv->offset = 0;
2170*4882a593Smuzhiyun lv->length = 1;
2171*4882a593Smuzhiyun dtlck->index++;
2172*4882a593Smuzhiyun
2173*4882a593Smuzhiyun /* linelock stbl of non-root leaf page */
2174*4882a593Smuzhiyun if (!(p->header.flag & BT_ROOT)) {
2175*4882a593Smuzhiyun if (dtlck->index >= dtlck->maxcnt)
2176*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
2177*4882a593Smuzhiyun lv = & dtlck->lv[dtlck->index];
2178*4882a593Smuzhiyun i = index >> L2DTSLOTSIZE;
2179*4882a593Smuzhiyun lv->offset = p->header.stblindex + i;
2180*4882a593Smuzhiyun lv->length =
2181*4882a593Smuzhiyun ((p->header.nextindex - 1) >> L2DTSLOTSIZE) -
2182*4882a593Smuzhiyun i + 1;
2183*4882a593Smuzhiyun dtlck->index++;
2184*4882a593Smuzhiyun }
2185*4882a593Smuzhiyun
2186*4882a593Smuzhiyun /* free the leaf entry */
2187*4882a593Smuzhiyun dtDeleteEntry(p, index, &dtlck);
2188*4882a593Smuzhiyun
2189*4882a593Smuzhiyun /*
2190*4882a593Smuzhiyun * Update directory index table for entries moved in stbl
2191*4882a593Smuzhiyun */
2192*4882a593Smuzhiyun if (DO_INDEX(ip) && index < p->header.nextindex) {
2193*4882a593Smuzhiyun s64 lblock;
2194*4882a593Smuzhiyun
2195*4882a593Smuzhiyun imp = NULL;
2196*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
2197*4882a593Smuzhiyun for (i = index; i < p->header.nextindex; i++) {
2198*4882a593Smuzhiyun ldtentry =
2199*4882a593Smuzhiyun (struct ldtentry *) & p->slot[stbl[i]];
2200*4882a593Smuzhiyun modify_index(tid, ip,
2201*4882a593Smuzhiyun le32_to_cpu(ldtentry->index),
2202*4882a593Smuzhiyun bn, i, &imp, &lblock);
2203*4882a593Smuzhiyun }
2204*4882a593Smuzhiyun if (imp)
2205*4882a593Smuzhiyun release_metapage(imp);
2206*4882a593Smuzhiyun }
2207*4882a593Smuzhiyun
2208*4882a593Smuzhiyun DT_PUTPAGE(mp);
2209*4882a593Smuzhiyun }
2210*4882a593Smuzhiyun
2211*4882a593Smuzhiyun return rc;
2212*4882a593Smuzhiyun }
2213*4882a593Smuzhiyun
2214*4882a593Smuzhiyun
2215*4882a593Smuzhiyun /*
2216*4882a593Smuzhiyun * dtDeleteUp()
2217*4882a593Smuzhiyun *
2218*4882a593Smuzhiyun * function:
2219*4882a593Smuzhiyun * free empty pages as propagating deletion up the tree
2220*4882a593Smuzhiyun *
2221*4882a593Smuzhiyun * parameter:
2222*4882a593Smuzhiyun *
2223*4882a593Smuzhiyun * return:
2224*4882a593Smuzhiyun */
dtDeleteUp(tid_t tid,struct inode * ip,struct metapage * fmp,dtpage_t * fp,struct btstack * btstack)2225*4882a593Smuzhiyun static int dtDeleteUp(tid_t tid, struct inode *ip,
2226*4882a593Smuzhiyun struct metapage * fmp, dtpage_t * fp, struct btstack * btstack)
2227*4882a593Smuzhiyun {
2228*4882a593Smuzhiyun int rc = 0;
2229*4882a593Smuzhiyun struct metapage *mp;
2230*4882a593Smuzhiyun dtpage_t *p;
2231*4882a593Smuzhiyun int index, nextindex;
2232*4882a593Smuzhiyun int xlen;
2233*4882a593Smuzhiyun struct btframe *parent;
2234*4882a593Smuzhiyun struct dt_lock *dtlck;
2235*4882a593Smuzhiyun struct tlock *tlck;
2236*4882a593Smuzhiyun struct lv *lv;
2237*4882a593Smuzhiyun struct pxd_lock *pxdlock;
2238*4882a593Smuzhiyun int i;
2239*4882a593Smuzhiyun
2240*4882a593Smuzhiyun /*
2241*4882a593Smuzhiyun * keep the root leaf page which has become empty
2242*4882a593Smuzhiyun */
2243*4882a593Smuzhiyun if (BT_IS_ROOT(fmp)) {
2244*4882a593Smuzhiyun /*
2245*4882a593Smuzhiyun * reset the root
2246*4882a593Smuzhiyun *
2247*4882a593Smuzhiyun * dtInitRoot() acquires txlock on the root
2248*4882a593Smuzhiyun */
2249*4882a593Smuzhiyun dtInitRoot(tid, ip, PARENT(ip));
2250*4882a593Smuzhiyun
2251*4882a593Smuzhiyun DT_PUTPAGE(fmp);
2252*4882a593Smuzhiyun
2253*4882a593Smuzhiyun return 0;
2254*4882a593Smuzhiyun }
2255*4882a593Smuzhiyun
2256*4882a593Smuzhiyun /*
2257*4882a593Smuzhiyun * free the non-root leaf page
2258*4882a593Smuzhiyun */
2259*4882a593Smuzhiyun /*
2260*4882a593Smuzhiyun * acquire a transaction lock on the page
2261*4882a593Smuzhiyun *
2262*4882a593Smuzhiyun * write FREEXTENT|NOREDOPAGE log record
2263*4882a593Smuzhiyun * N.B. linelock is overlaid as freed extent descriptor, and
2264*4882a593Smuzhiyun * the buffer page is freed;
2265*4882a593Smuzhiyun */
2266*4882a593Smuzhiyun tlck = txMaplock(tid, ip, tlckDTREE | tlckFREE);
2267*4882a593Smuzhiyun pxdlock = (struct pxd_lock *) & tlck->lock;
2268*4882a593Smuzhiyun pxdlock->flag = mlckFREEPXD;
2269*4882a593Smuzhiyun pxdlock->pxd = fp->header.self;
2270*4882a593Smuzhiyun pxdlock->index = 1;
2271*4882a593Smuzhiyun
2272*4882a593Smuzhiyun /* update sibling pointers */
2273*4882a593Smuzhiyun if ((rc = dtRelink(tid, ip, fp))) {
2274*4882a593Smuzhiyun BT_PUTPAGE(fmp);
2275*4882a593Smuzhiyun return rc;
2276*4882a593Smuzhiyun }
2277*4882a593Smuzhiyun
2278*4882a593Smuzhiyun xlen = lengthPXD(&fp->header.self);
2279*4882a593Smuzhiyun
2280*4882a593Smuzhiyun /* Free quota allocation. */
2281*4882a593Smuzhiyun dquot_free_block(ip, xlen);
2282*4882a593Smuzhiyun
2283*4882a593Smuzhiyun /* free/invalidate its buffer page */
2284*4882a593Smuzhiyun discard_metapage(fmp);
2285*4882a593Smuzhiyun
2286*4882a593Smuzhiyun /*
2287*4882a593Smuzhiyun * propagate page deletion up the directory tree
2288*4882a593Smuzhiyun *
2289*4882a593Smuzhiyun * If the delete from the parent page makes it empty,
2290*4882a593Smuzhiyun * continue all the way up the tree.
2291*4882a593Smuzhiyun * stop if the root page is reached (which is never deleted) or
2292*4882a593Smuzhiyun * if the entry deletion does not empty the page.
2293*4882a593Smuzhiyun */
2294*4882a593Smuzhiyun while ((parent = BT_POP(btstack)) != NULL) {
2295*4882a593Smuzhiyun /* pin the parent page <sp> */
2296*4882a593Smuzhiyun DT_GETPAGE(ip, parent->bn, mp, PSIZE, p, rc);
2297*4882a593Smuzhiyun if (rc)
2298*4882a593Smuzhiyun return rc;
2299*4882a593Smuzhiyun
2300*4882a593Smuzhiyun /*
2301*4882a593Smuzhiyun * free the extent of the child page deleted
2302*4882a593Smuzhiyun */
2303*4882a593Smuzhiyun index = parent->index;
2304*4882a593Smuzhiyun
2305*4882a593Smuzhiyun /*
2306*4882a593Smuzhiyun * delete the entry for the child page from parent
2307*4882a593Smuzhiyun */
2308*4882a593Smuzhiyun nextindex = p->header.nextindex;
2309*4882a593Smuzhiyun
2310*4882a593Smuzhiyun /*
2311*4882a593Smuzhiyun * the parent has the single entry being deleted:
2312*4882a593Smuzhiyun *
2313*4882a593Smuzhiyun * free the parent page which has become empty.
2314*4882a593Smuzhiyun */
2315*4882a593Smuzhiyun if (nextindex == 1) {
2316*4882a593Smuzhiyun /*
2317*4882a593Smuzhiyun * keep the root internal page which has become empty
2318*4882a593Smuzhiyun */
2319*4882a593Smuzhiyun if (p->header.flag & BT_ROOT) {
2320*4882a593Smuzhiyun /*
2321*4882a593Smuzhiyun * reset the root
2322*4882a593Smuzhiyun *
2323*4882a593Smuzhiyun * dtInitRoot() acquires txlock on the root
2324*4882a593Smuzhiyun */
2325*4882a593Smuzhiyun dtInitRoot(tid, ip, PARENT(ip));
2326*4882a593Smuzhiyun
2327*4882a593Smuzhiyun DT_PUTPAGE(mp);
2328*4882a593Smuzhiyun
2329*4882a593Smuzhiyun return 0;
2330*4882a593Smuzhiyun }
2331*4882a593Smuzhiyun /*
2332*4882a593Smuzhiyun * free the parent page
2333*4882a593Smuzhiyun */
2334*4882a593Smuzhiyun else {
2335*4882a593Smuzhiyun /*
2336*4882a593Smuzhiyun * acquire a transaction lock on the page
2337*4882a593Smuzhiyun *
2338*4882a593Smuzhiyun * write FREEXTENT|NOREDOPAGE log record
2339*4882a593Smuzhiyun */
2340*4882a593Smuzhiyun tlck =
2341*4882a593Smuzhiyun txMaplock(tid, ip,
2342*4882a593Smuzhiyun tlckDTREE | tlckFREE);
2343*4882a593Smuzhiyun pxdlock = (struct pxd_lock *) & tlck->lock;
2344*4882a593Smuzhiyun pxdlock->flag = mlckFREEPXD;
2345*4882a593Smuzhiyun pxdlock->pxd = p->header.self;
2346*4882a593Smuzhiyun pxdlock->index = 1;
2347*4882a593Smuzhiyun
2348*4882a593Smuzhiyun /* update sibling pointers */
2349*4882a593Smuzhiyun if ((rc = dtRelink(tid, ip, p))) {
2350*4882a593Smuzhiyun DT_PUTPAGE(mp);
2351*4882a593Smuzhiyun return rc;
2352*4882a593Smuzhiyun }
2353*4882a593Smuzhiyun
2354*4882a593Smuzhiyun xlen = lengthPXD(&p->header.self);
2355*4882a593Smuzhiyun
2356*4882a593Smuzhiyun /* Free quota allocation */
2357*4882a593Smuzhiyun dquot_free_block(ip, xlen);
2358*4882a593Smuzhiyun
2359*4882a593Smuzhiyun /* free/invalidate its buffer page */
2360*4882a593Smuzhiyun discard_metapage(mp);
2361*4882a593Smuzhiyun
2362*4882a593Smuzhiyun /* propagate up */
2363*4882a593Smuzhiyun continue;
2364*4882a593Smuzhiyun }
2365*4882a593Smuzhiyun }
2366*4882a593Smuzhiyun
2367*4882a593Smuzhiyun /*
2368*4882a593Smuzhiyun * the parent has other entries remaining:
2369*4882a593Smuzhiyun *
2370*4882a593Smuzhiyun * delete the router entry from the parent page.
2371*4882a593Smuzhiyun */
2372*4882a593Smuzhiyun BT_MARK_DIRTY(mp, ip);
2373*4882a593Smuzhiyun /*
2374*4882a593Smuzhiyun * acquire a transaction lock on the page
2375*4882a593Smuzhiyun *
2376*4882a593Smuzhiyun * action: router entry deletion
2377*4882a593Smuzhiyun */
2378*4882a593Smuzhiyun tlck = txLock(tid, ip, mp, tlckDTREE | tlckENTRY);
2379*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
2380*4882a593Smuzhiyun
2381*4882a593Smuzhiyun /* linelock header */
2382*4882a593Smuzhiyun if (dtlck->index >= dtlck->maxcnt)
2383*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
2384*4882a593Smuzhiyun lv = & dtlck->lv[dtlck->index];
2385*4882a593Smuzhiyun lv->offset = 0;
2386*4882a593Smuzhiyun lv->length = 1;
2387*4882a593Smuzhiyun dtlck->index++;
2388*4882a593Smuzhiyun
2389*4882a593Smuzhiyun /* linelock stbl of non-root leaf page */
2390*4882a593Smuzhiyun if (!(p->header.flag & BT_ROOT)) {
2391*4882a593Smuzhiyun if (dtlck->index < dtlck->maxcnt)
2392*4882a593Smuzhiyun lv++;
2393*4882a593Smuzhiyun else {
2394*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
2395*4882a593Smuzhiyun lv = & dtlck->lv[0];
2396*4882a593Smuzhiyun }
2397*4882a593Smuzhiyun i = index >> L2DTSLOTSIZE;
2398*4882a593Smuzhiyun lv->offset = p->header.stblindex + i;
2399*4882a593Smuzhiyun lv->length =
2400*4882a593Smuzhiyun ((p->header.nextindex - 1) >> L2DTSLOTSIZE) -
2401*4882a593Smuzhiyun i + 1;
2402*4882a593Smuzhiyun dtlck->index++;
2403*4882a593Smuzhiyun }
2404*4882a593Smuzhiyun
2405*4882a593Smuzhiyun /* free the router entry */
2406*4882a593Smuzhiyun dtDeleteEntry(p, index, &dtlck);
2407*4882a593Smuzhiyun
2408*4882a593Smuzhiyun /* reset key of new leftmost entry of level (for consistency) */
2409*4882a593Smuzhiyun if (index == 0 &&
2410*4882a593Smuzhiyun ((p->header.flag & BT_ROOT) || p->header.prev == 0))
2411*4882a593Smuzhiyun dtTruncateEntry(p, 0, &dtlck);
2412*4882a593Smuzhiyun
2413*4882a593Smuzhiyun /* unpin the parent page */
2414*4882a593Smuzhiyun DT_PUTPAGE(mp);
2415*4882a593Smuzhiyun
2416*4882a593Smuzhiyun /* exit propagation up */
2417*4882a593Smuzhiyun break;
2418*4882a593Smuzhiyun }
2419*4882a593Smuzhiyun
2420*4882a593Smuzhiyun if (!DO_INDEX(ip))
2421*4882a593Smuzhiyun ip->i_size -= PSIZE;
2422*4882a593Smuzhiyun
2423*4882a593Smuzhiyun return 0;
2424*4882a593Smuzhiyun }
2425*4882a593Smuzhiyun
2426*4882a593Smuzhiyun #ifdef _NOTYET
2427*4882a593Smuzhiyun /*
2428*4882a593Smuzhiyun * NAME: dtRelocate()
2429*4882a593Smuzhiyun *
2430*4882a593Smuzhiyun * FUNCTION: relocate dtpage (internal or leaf) of directory;
2431*4882a593Smuzhiyun * This function is mainly used by defragfs utility.
2432*4882a593Smuzhiyun */
dtRelocate(tid_t tid,struct inode * ip,s64 lmxaddr,pxd_t * opxd,s64 nxaddr)2433*4882a593Smuzhiyun int dtRelocate(tid_t tid, struct inode *ip, s64 lmxaddr, pxd_t * opxd,
2434*4882a593Smuzhiyun s64 nxaddr)
2435*4882a593Smuzhiyun {
2436*4882a593Smuzhiyun int rc = 0;
2437*4882a593Smuzhiyun struct metapage *mp, *pmp, *lmp, *rmp;
2438*4882a593Smuzhiyun dtpage_t *p, *pp, *rp = 0, *lp= 0;
2439*4882a593Smuzhiyun s64 bn;
2440*4882a593Smuzhiyun int index;
2441*4882a593Smuzhiyun struct btstack btstack;
2442*4882a593Smuzhiyun pxd_t *pxd;
2443*4882a593Smuzhiyun s64 oxaddr, nextbn, prevbn;
2444*4882a593Smuzhiyun int xlen, xsize;
2445*4882a593Smuzhiyun struct tlock *tlck;
2446*4882a593Smuzhiyun struct dt_lock *dtlck;
2447*4882a593Smuzhiyun struct pxd_lock *pxdlock;
2448*4882a593Smuzhiyun s8 *stbl;
2449*4882a593Smuzhiyun struct lv *lv;
2450*4882a593Smuzhiyun
2451*4882a593Smuzhiyun oxaddr = addressPXD(opxd);
2452*4882a593Smuzhiyun xlen = lengthPXD(opxd);
2453*4882a593Smuzhiyun
2454*4882a593Smuzhiyun jfs_info("dtRelocate: lmxaddr:%Ld xaddr:%Ld:%Ld xlen:%d",
2455*4882a593Smuzhiyun (long long)lmxaddr, (long long)oxaddr, (long long)nxaddr,
2456*4882a593Smuzhiyun xlen);
2457*4882a593Smuzhiyun
2458*4882a593Smuzhiyun /*
2459*4882a593Smuzhiyun * 1. get the internal parent dtpage covering
2460*4882a593Smuzhiyun * router entry for the tartget page to be relocated;
2461*4882a593Smuzhiyun */
2462*4882a593Smuzhiyun rc = dtSearchNode(ip, lmxaddr, opxd, &btstack);
2463*4882a593Smuzhiyun if (rc)
2464*4882a593Smuzhiyun return rc;
2465*4882a593Smuzhiyun
2466*4882a593Smuzhiyun /* retrieve search result */
2467*4882a593Smuzhiyun DT_GETSEARCH(ip, btstack.top, bn, pmp, pp, index);
2468*4882a593Smuzhiyun jfs_info("dtRelocate: parent router entry validated.");
2469*4882a593Smuzhiyun
2470*4882a593Smuzhiyun /*
2471*4882a593Smuzhiyun * 2. relocate the target dtpage
2472*4882a593Smuzhiyun */
2473*4882a593Smuzhiyun /* read in the target page from src extent */
2474*4882a593Smuzhiyun DT_GETPAGE(ip, oxaddr, mp, PSIZE, p, rc);
2475*4882a593Smuzhiyun if (rc) {
2476*4882a593Smuzhiyun /* release the pinned parent page */
2477*4882a593Smuzhiyun DT_PUTPAGE(pmp);
2478*4882a593Smuzhiyun return rc;
2479*4882a593Smuzhiyun }
2480*4882a593Smuzhiyun
2481*4882a593Smuzhiyun /*
2482*4882a593Smuzhiyun * read in sibling pages if any to update sibling pointers;
2483*4882a593Smuzhiyun */
2484*4882a593Smuzhiyun rmp = NULL;
2485*4882a593Smuzhiyun if (p->header.next) {
2486*4882a593Smuzhiyun nextbn = le64_to_cpu(p->header.next);
2487*4882a593Smuzhiyun DT_GETPAGE(ip, nextbn, rmp, PSIZE, rp, rc);
2488*4882a593Smuzhiyun if (rc) {
2489*4882a593Smuzhiyun DT_PUTPAGE(mp);
2490*4882a593Smuzhiyun DT_PUTPAGE(pmp);
2491*4882a593Smuzhiyun return (rc);
2492*4882a593Smuzhiyun }
2493*4882a593Smuzhiyun }
2494*4882a593Smuzhiyun
2495*4882a593Smuzhiyun lmp = NULL;
2496*4882a593Smuzhiyun if (p->header.prev) {
2497*4882a593Smuzhiyun prevbn = le64_to_cpu(p->header.prev);
2498*4882a593Smuzhiyun DT_GETPAGE(ip, prevbn, lmp, PSIZE, lp, rc);
2499*4882a593Smuzhiyun if (rc) {
2500*4882a593Smuzhiyun DT_PUTPAGE(mp);
2501*4882a593Smuzhiyun DT_PUTPAGE(pmp);
2502*4882a593Smuzhiyun if (rmp)
2503*4882a593Smuzhiyun DT_PUTPAGE(rmp);
2504*4882a593Smuzhiyun return (rc);
2505*4882a593Smuzhiyun }
2506*4882a593Smuzhiyun }
2507*4882a593Smuzhiyun
2508*4882a593Smuzhiyun /* at this point, all xtpages to be updated are in memory */
2509*4882a593Smuzhiyun
2510*4882a593Smuzhiyun /*
2511*4882a593Smuzhiyun * update sibling pointers of sibling dtpages if any;
2512*4882a593Smuzhiyun */
2513*4882a593Smuzhiyun if (lmp) {
2514*4882a593Smuzhiyun tlck = txLock(tid, ip, lmp, tlckDTREE | tlckRELINK);
2515*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
2516*4882a593Smuzhiyun /* linelock header */
2517*4882a593Smuzhiyun ASSERT(dtlck->index == 0);
2518*4882a593Smuzhiyun lv = & dtlck->lv[0];
2519*4882a593Smuzhiyun lv->offset = 0;
2520*4882a593Smuzhiyun lv->length = 1;
2521*4882a593Smuzhiyun dtlck->index++;
2522*4882a593Smuzhiyun
2523*4882a593Smuzhiyun lp->header.next = cpu_to_le64(nxaddr);
2524*4882a593Smuzhiyun DT_PUTPAGE(lmp);
2525*4882a593Smuzhiyun }
2526*4882a593Smuzhiyun
2527*4882a593Smuzhiyun if (rmp) {
2528*4882a593Smuzhiyun tlck = txLock(tid, ip, rmp, tlckDTREE | tlckRELINK);
2529*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
2530*4882a593Smuzhiyun /* linelock header */
2531*4882a593Smuzhiyun ASSERT(dtlck->index == 0);
2532*4882a593Smuzhiyun lv = & dtlck->lv[0];
2533*4882a593Smuzhiyun lv->offset = 0;
2534*4882a593Smuzhiyun lv->length = 1;
2535*4882a593Smuzhiyun dtlck->index++;
2536*4882a593Smuzhiyun
2537*4882a593Smuzhiyun rp->header.prev = cpu_to_le64(nxaddr);
2538*4882a593Smuzhiyun DT_PUTPAGE(rmp);
2539*4882a593Smuzhiyun }
2540*4882a593Smuzhiyun
2541*4882a593Smuzhiyun /*
2542*4882a593Smuzhiyun * update the target dtpage to be relocated
2543*4882a593Smuzhiyun *
2544*4882a593Smuzhiyun * write LOG_REDOPAGE of LOG_NEW type for dst page
2545*4882a593Smuzhiyun * for the whole target page (logredo() will apply
2546*4882a593Smuzhiyun * after image and update bmap for allocation of the
2547*4882a593Smuzhiyun * dst extent), and update bmap for allocation of
2548*4882a593Smuzhiyun * the dst extent;
2549*4882a593Smuzhiyun */
2550*4882a593Smuzhiyun tlck = txLock(tid, ip, mp, tlckDTREE | tlckNEW);
2551*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
2552*4882a593Smuzhiyun /* linelock header */
2553*4882a593Smuzhiyun ASSERT(dtlck->index == 0);
2554*4882a593Smuzhiyun lv = & dtlck->lv[0];
2555*4882a593Smuzhiyun
2556*4882a593Smuzhiyun /* update the self address in the dtpage header */
2557*4882a593Smuzhiyun pxd = &p->header.self;
2558*4882a593Smuzhiyun PXDaddress(pxd, nxaddr);
2559*4882a593Smuzhiyun
2560*4882a593Smuzhiyun /* the dst page is the same as the src page, i.e.,
2561*4882a593Smuzhiyun * linelock for afterimage of the whole page;
2562*4882a593Smuzhiyun */
2563*4882a593Smuzhiyun lv->offset = 0;
2564*4882a593Smuzhiyun lv->length = p->header.maxslot;
2565*4882a593Smuzhiyun dtlck->index++;
2566*4882a593Smuzhiyun
2567*4882a593Smuzhiyun /* update the buffer extent descriptor of the dtpage */
2568*4882a593Smuzhiyun xsize = xlen << JFS_SBI(ip->i_sb)->l2bsize;
2569*4882a593Smuzhiyun
2570*4882a593Smuzhiyun /* unpin the relocated page */
2571*4882a593Smuzhiyun DT_PUTPAGE(mp);
2572*4882a593Smuzhiyun jfs_info("dtRelocate: target dtpage relocated.");
2573*4882a593Smuzhiyun
2574*4882a593Smuzhiyun /* the moved extent is dtpage, then a LOG_NOREDOPAGE log rec
2575*4882a593Smuzhiyun * needs to be written (in logredo(), the LOG_NOREDOPAGE log rec
2576*4882a593Smuzhiyun * will also force a bmap update ).
2577*4882a593Smuzhiyun */
2578*4882a593Smuzhiyun
2579*4882a593Smuzhiyun /*
2580*4882a593Smuzhiyun * 3. acquire maplock for the source extent to be freed;
2581*4882a593Smuzhiyun */
2582*4882a593Smuzhiyun /* for dtpage relocation, write a LOG_NOREDOPAGE record
2583*4882a593Smuzhiyun * for the source dtpage (logredo() will init NoRedoPage
2584*4882a593Smuzhiyun * filter and will also update bmap for free of the source
2585*4882a593Smuzhiyun * dtpage), and upadte bmap for free of the source dtpage;
2586*4882a593Smuzhiyun */
2587*4882a593Smuzhiyun tlck = txMaplock(tid, ip, tlckDTREE | tlckFREE);
2588*4882a593Smuzhiyun pxdlock = (struct pxd_lock *) & tlck->lock;
2589*4882a593Smuzhiyun pxdlock->flag = mlckFREEPXD;
2590*4882a593Smuzhiyun PXDaddress(&pxdlock->pxd, oxaddr);
2591*4882a593Smuzhiyun PXDlength(&pxdlock->pxd, xlen);
2592*4882a593Smuzhiyun pxdlock->index = 1;
2593*4882a593Smuzhiyun
2594*4882a593Smuzhiyun /*
2595*4882a593Smuzhiyun * 4. update the parent router entry for relocation;
2596*4882a593Smuzhiyun *
2597*4882a593Smuzhiyun * acquire tlck for the parent entry covering the target dtpage;
2598*4882a593Smuzhiyun * write LOG_REDOPAGE to apply after image only;
2599*4882a593Smuzhiyun */
2600*4882a593Smuzhiyun jfs_info("dtRelocate: update parent router entry.");
2601*4882a593Smuzhiyun tlck = txLock(tid, ip, pmp, tlckDTREE | tlckENTRY);
2602*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
2603*4882a593Smuzhiyun lv = & dtlck->lv[dtlck->index];
2604*4882a593Smuzhiyun
2605*4882a593Smuzhiyun /* update the PXD with the new address */
2606*4882a593Smuzhiyun stbl = DT_GETSTBL(pp);
2607*4882a593Smuzhiyun pxd = (pxd_t *) & pp->slot[stbl[index]];
2608*4882a593Smuzhiyun PXDaddress(pxd, nxaddr);
2609*4882a593Smuzhiyun lv->offset = stbl[index];
2610*4882a593Smuzhiyun lv->length = 1;
2611*4882a593Smuzhiyun dtlck->index++;
2612*4882a593Smuzhiyun
2613*4882a593Smuzhiyun /* unpin the parent dtpage */
2614*4882a593Smuzhiyun DT_PUTPAGE(pmp);
2615*4882a593Smuzhiyun
2616*4882a593Smuzhiyun return rc;
2617*4882a593Smuzhiyun }
2618*4882a593Smuzhiyun
2619*4882a593Smuzhiyun /*
2620*4882a593Smuzhiyun * NAME: dtSearchNode()
2621*4882a593Smuzhiyun *
2622*4882a593Smuzhiyun * FUNCTION: Search for an dtpage containing a specified address
2623*4882a593Smuzhiyun * This function is mainly used by defragfs utility.
2624*4882a593Smuzhiyun *
2625*4882a593Smuzhiyun * NOTE: Search result on stack, the found page is pinned at exit.
2626*4882a593Smuzhiyun * The result page must be an internal dtpage.
2627*4882a593Smuzhiyun * lmxaddr give the address of the left most page of the
2628*4882a593Smuzhiyun * dtree level, in which the required dtpage resides.
2629*4882a593Smuzhiyun */
dtSearchNode(struct inode * ip,s64 lmxaddr,pxd_t * kpxd,struct btstack * btstack)2630*4882a593Smuzhiyun static int dtSearchNode(struct inode *ip, s64 lmxaddr, pxd_t * kpxd,
2631*4882a593Smuzhiyun struct btstack * btstack)
2632*4882a593Smuzhiyun {
2633*4882a593Smuzhiyun int rc = 0;
2634*4882a593Smuzhiyun s64 bn;
2635*4882a593Smuzhiyun struct metapage *mp;
2636*4882a593Smuzhiyun dtpage_t *p;
2637*4882a593Smuzhiyun int psize = 288; /* initial in-line directory */
2638*4882a593Smuzhiyun s8 *stbl;
2639*4882a593Smuzhiyun int i;
2640*4882a593Smuzhiyun pxd_t *pxd;
2641*4882a593Smuzhiyun struct btframe *btsp;
2642*4882a593Smuzhiyun
2643*4882a593Smuzhiyun BT_CLR(btstack); /* reset stack */
2644*4882a593Smuzhiyun
2645*4882a593Smuzhiyun /*
2646*4882a593Smuzhiyun * descend tree to the level with specified leftmost page
2647*4882a593Smuzhiyun *
2648*4882a593Smuzhiyun * by convention, root bn = 0.
2649*4882a593Smuzhiyun */
2650*4882a593Smuzhiyun for (bn = 0;;) {
2651*4882a593Smuzhiyun /* get/pin the page to search */
2652*4882a593Smuzhiyun DT_GETPAGE(ip, bn, mp, psize, p, rc);
2653*4882a593Smuzhiyun if (rc)
2654*4882a593Smuzhiyun return rc;
2655*4882a593Smuzhiyun
2656*4882a593Smuzhiyun /* does the xaddr of leftmost page of the levevl
2657*4882a593Smuzhiyun * matches levevl search key ?
2658*4882a593Smuzhiyun */
2659*4882a593Smuzhiyun if (p->header.flag & BT_ROOT) {
2660*4882a593Smuzhiyun if (lmxaddr == 0)
2661*4882a593Smuzhiyun break;
2662*4882a593Smuzhiyun } else if (addressPXD(&p->header.self) == lmxaddr)
2663*4882a593Smuzhiyun break;
2664*4882a593Smuzhiyun
2665*4882a593Smuzhiyun /*
2666*4882a593Smuzhiyun * descend down to leftmost child page
2667*4882a593Smuzhiyun */
2668*4882a593Smuzhiyun if (p->header.flag & BT_LEAF) {
2669*4882a593Smuzhiyun DT_PUTPAGE(mp);
2670*4882a593Smuzhiyun return -ESTALE;
2671*4882a593Smuzhiyun }
2672*4882a593Smuzhiyun
2673*4882a593Smuzhiyun /* get the leftmost entry */
2674*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
2675*4882a593Smuzhiyun pxd = (pxd_t *) & p->slot[stbl[0]];
2676*4882a593Smuzhiyun
2677*4882a593Smuzhiyun /* get the child page block address */
2678*4882a593Smuzhiyun bn = addressPXD(pxd);
2679*4882a593Smuzhiyun psize = lengthPXD(pxd) << JFS_SBI(ip->i_sb)->l2bsize;
2680*4882a593Smuzhiyun /* unpin the parent page */
2681*4882a593Smuzhiyun DT_PUTPAGE(mp);
2682*4882a593Smuzhiyun }
2683*4882a593Smuzhiyun
2684*4882a593Smuzhiyun /*
2685*4882a593Smuzhiyun * search each page at the current levevl
2686*4882a593Smuzhiyun */
2687*4882a593Smuzhiyun loop:
2688*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
2689*4882a593Smuzhiyun for (i = 0; i < p->header.nextindex; i++) {
2690*4882a593Smuzhiyun pxd = (pxd_t *) & p->slot[stbl[i]];
2691*4882a593Smuzhiyun
2692*4882a593Smuzhiyun /* found the specified router entry */
2693*4882a593Smuzhiyun if (addressPXD(pxd) == addressPXD(kpxd) &&
2694*4882a593Smuzhiyun lengthPXD(pxd) == lengthPXD(kpxd)) {
2695*4882a593Smuzhiyun btsp = btstack->top;
2696*4882a593Smuzhiyun btsp->bn = bn;
2697*4882a593Smuzhiyun btsp->index = i;
2698*4882a593Smuzhiyun btsp->mp = mp;
2699*4882a593Smuzhiyun
2700*4882a593Smuzhiyun return 0;
2701*4882a593Smuzhiyun }
2702*4882a593Smuzhiyun }
2703*4882a593Smuzhiyun
2704*4882a593Smuzhiyun /* get the right sibling page if any */
2705*4882a593Smuzhiyun if (p->header.next)
2706*4882a593Smuzhiyun bn = le64_to_cpu(p->header.next);
2707*4882a593Smuzhiyun else {
2708*4882a593Smuzhiyun DT_PUTPAGE(mp);
2709*4882a593Smuzhiyun return -ESTALE;
2710*4882a593Smuzhiyun }
2711*4882a593Smuzhiyun
2712*4882a593Smuzhiyun /* unpin current page */
2713*4882a593Smuzhiyun DT_PUTPAGE(mp);
2714*4882a593Smuzhiyun
2715*4882a593Smuzhiyun /* get the right sibling page */
2716*4882a593Smuzhiyun DT_GETPAGE(ip, bn, mp, PSIZE, p, rc);
2717*4882a593Smuzhiyun if (rc)
2718*4882a593Smuzhiyun return rc;
2719*4882a593Smuzhiyun
2720*4882a593Smuzhiyun goto loop;
2721*4882a593Smuzhiyun }
2722*4882a593Smuzhiyun #endif /* _NOTYET */
2723*4882a593Smuzhiyun
2724*4882a593Smuzhiyun /*
2725*4882a593Smuzhiyun * dtRelink()
2726*4882a593Smuzhiyun *
2727*4882a593Smuzhiyun * function:
2728*4882a593Smuzhiyun * link around a freed page.
2729*4882a593Smuzhiyun *
2730*4882a593Smuzhiyun * parameter:
2731*4882a593Smuzhiyun * fp: page to be freed
2732*4882a593Smuzhiyun *
2733*4882a593Smuzhiyun * return:
2734*4882a593Smuzhiyun */
dtRelink(tid_t tid,struct inode * ip,dtpage_t * p)2735*4882a593Smuzhiyun static int dtRelink(tid_t tid, struct inode *ip, dtpage_t * p)
2736*4882a593Smuzhiyun {
2737*4882a593Smuzhiyun int rc;
2738*4882a593Smuzhiyun struct metapage *mp;
2739*4882a593Smuzhiyun s64 nextbn, prevbn;
2740*4882a593Smuzhiyun struct tlock *tlck;
2741*4882a593Smuzhiyun struct dt_lock *dtlck;
2742*4882a593Smuzhiyun struct lv *lv;
2743*4882a593Smuzhiyun
2744*4882a593Smuzhiyun nextbn = le64_to_cpu(p->header.next);
2745*4882a593Smuzhiyun prevbn = le64_to_cpu(p->header.prev);
2746*4882a593Smuzhiyun
2747*4882a593Smuzhiyun /* update prev pointer of the next page */
2748*4882a593Smuzhiyun if (nextbn != 0) {
2749*4882a593Smuzhiyun DT_GETPAGE(ip, nextbn, mp, PSIZE, p, rc);
2750*4882a593Smuzhiyun if (rc)
2751*4882a593Smuzhiyun return rc;
2752*4882a593Smuzhiyun
2753*4882a593Smuzhiyun BT_MARK_DIRTY(mp, ip);
2754*4882a593Smuzhiyun /*
2755*4882a593Smuzhiyun * acquire a transaction lock on the next page
2756*4882a593Smuzhiyun *
2757*4882a593Smuzhiyun * action: update prev pointer;
2758*4882a593Smuzhiyun */
2759*4882a593Smuzhiyun tlck = txLock(tid, ip, mp, tlckDTREE | tlckRELINK);
2760*4882a593Smuzhiyun jfs_info("dtRelink nextbn: tlck = 0x%p, ip = 0x%p, mp=0x%p",
2761*4882a593Smuzhiyun tlck, ip, mp);
2762*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
2763*4882a593Smuzhiyun
2764*4882a593Smuzhiyun /* linelock header */
2765*4882a593Smuzhiyun if (dtlck->index >= dtlck->maxcnt)
2766*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
2767*4882a593Smuzhiyun lv = & dtlck->lv[dtlck->index];
2768*4882a593Smuzhiyun lv->offset = 0;
2769*4882a593Smuzhiyun lv->length = 1;
2770*4882a593Smuzhiyun dtlck->index++;
2771*4882a593Smuzhiyun
2772*4882a593Smuzhiyun p->header.prev = cpu_to_le64(prevbn);
2773*4882a593Smuzhiyun DT_PUTPAGE(mp);
2774*4882a593Smuzhiyun }
2775*4882a593Smuzhiyun
2776*4882a593Smuzhiyun /* update next pointer of the previous page */
2777*4882a593Smuzhiyun if (prevbn != 0) {
2778*4882a593Smuzhiyun DT_GETPAGE(ip, prevbn, mp, PSIZE, p, rc);
2779*4882a593Smuzhiyun if (rc)
2780*4882a593Smuzhiyun return rc;
2781*4882a593Smuzhiyun
2782*4882a593Smuzhiyun BT_MARK_DIRTY(mp, ip);
2783*4882a593Smuzhiyun /*
2784*4882a593Smuzhiyun * acquire a transaction lock on the prev page
2785*4882a593Smuzhiyun *
2786*4882a593Smuzhiyun * action: update next pointer;
2787*4882a593Smuzhiyun */
2788*4882a593Smuzhiyun tlck = txLock(tid, ip, mp, tlckDTREE | tlckRELINK);
2789*4882a593Smuzhiyun jfs_info("dtRelink prevbn: tlck = 0x%p, ip = 0x%p, mp=0x%p",
2790*4882a593Smuzhiyun tlck, ip, mp);
2791*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
2792*4882a593Smuzhiyun
2793*4882a593Smuzhiyun /* linelock header */
2794*4882a593Smuzhiyun if (dtlck->index >= dtlck->maxcnt)
2795*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
2796*4882a593Smuzhiyun lv = & dtlck->lv[dtlck->index];
2797*4882a593Smuzhiyun lv->offset = 0;
2798*4882a593Smuzhiyun lv->length = 1;
2799*4882a593Smuzhiyun dtlck->index++;
2800*4882a593Smuzhiyun
2801*4882a593Smuzhiyun p->header.next = cpu_to_le64(nextbn);
2802*4882a593Smuzhiyun DT_PUTPAGE(mp);
2803*4882a593Smuzhiyun }
2804*4882a593Smuzhiyun
2805*4882a593Smuzhiyun return 0;
2806*4882a593Smuzhiyun }
2807*4882a593Smuzhiyun
2808*4882a593Smuzhiyun
2809*4882a593Smuzhiyun /*
2810*4882a593Smuzhiyun * dtInitRoot()
2811*4882a593Smuzhiyun *
2812*4882a593Smuzhiyun * initialize directory root (inline in inode)
2813*4882a593Smuzhiyun */
dtInitRoot(tid_t tid,struct inode * ip,u32 idotdot)2814*4882a593Smuzhiyun void dtInitRoot(tid_t tid, struct inode *ip, u32 idotdot)
2815*4882a593Smuzhiyun {
2816*4882a593Smuzhiyun struct jfs_inode_info *jfs_ip = JFS_IP(ip);
2817*4882a593Smuzhiyun dtroot_t *p;
2818*4882a593Smuzhiyun int fsi;
2819*4882a593Smuzhiyun struct dtslot *f;
2820*4882a593Smuzhiyun struct tlock *tlck;
2821*4882a593Smuzhiyun struct dt_lock *dtlck;
2822*4882a593Smuzhiyun struct lv *lv;
2823*4882a593Smuzhiyun u16 xflag_save;
2824*4882a593Smuzhiyun
2825*4882a593Smuzhiyun /*
2826*4882a593Smuzhiyun * If this was previously an non-empty directory, we need to remove
2827*4882a593Smuzhiyun * the old directory table.
2828*4882a593Smuzhiyun */
2829*4882a593Smuzhiyun if (DO_INDEX(ip)) {
2830*4882a593Smuzhiyun if (!jfs_dirtable_inline(ip)) {
2831*4882a593Smuzhiyun struct tblock *tblk = tid_to_tblock(tid);
2832*4882a593Smuzhiyun /*
2833*4882a593Smuzhiyun * We're playing games with the tid's xflag. If
2834*4882a593Smuzhiyun * we're removing a regular file, the file's xtree
2835*4882a593Smuzhiyun * is committed with COMMIT_PMAP, but we always
2836*4882a593Smuzhiyun * commit the directories xtree with COMMIT_PWMAP.
2837*4882a593Smuzhiyun */
2838*4882a593Smuzhiyun xflag_save = tblk->xflag;
2839*4882a593Smuzhiyun tblk->xflag = 0;
2840*4882a593Smuzhiyun /*
2841*4882a593Smuzhiyun * xtTruncate isn't guaranteed to fully truncate
2842*4882a593Smuzhiyun * the xtree. The caller needs to check i_size
2843*4882a593Smuzhiyun * after committing the transaction to see if
2844*4882a593Smuzhiyun * additional truncation is needed. The
2845*4882a593Smuzhiyun * COMMIT_Stale flag tells caller that we
2846*4882a593Smuzhiyun * initiated the truncation.
2847*4882a593Smuzhiyun */
2848*4882a593Smuzhiyun xtTruncate(tid, ip, 0, COMMIT_PWMAP);
2849*4882a593Smuzhiyun set_cflag(COMMIT_Stale, ip);
2850*4882a593Smuzhiyun
2851*4882a593Smuzhiyun tblk->xflag = xflag_save;
2852*4882a593Smuzhiyun } else
2853*4882a593Smuzhiyun ip->i_size = 1;
2854*4882a593Smuzhiyun
2855*4882a593Smuzhiyun jfs_ip->next_index = 2;
2856*4882a593Smuzhiyun } else
2857*4882a593Smuzhiyun ip->i_size = IDATASIZE;
2858*4882a593Smuzhiyun
2859*4882a593Smuzhiyun /*
2860*4882a593Smuzhiyun * acquire a transaction lock on the root
2861*4882a593Smuzhiyun *
2862*4882a593Smuzhiyun * action: directory initialization;
2863*4882a593Smuzhiyun */
2864*4882a593Smuzhiyun tlck = txLock(tid, ip, (struct metapage *) & jfs_ip->bxflag,
2865*4882a593Smuzhiyun tlckDTREE | tlckENTRY | tlckBTROOT);
2866*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
2867*4882a593Smuzhiyun
2868*4882a593Smuzhiyun /* linelock root */
2869*4882a593Smuzhiyun ASSERT(dtlck->index == 0);
2870*4882a593Smuzhiyun lv = & dtlck->lv[0];
2871*4882a593Smuzhiyun lv->offset = 0;
2872*4882a593Smuzhiyun lv->length = DTROOTMAXSLOT;
2873*4882a593Smuzhiyun dtlck->index++;
2874*4882a593Smuzhiyun
2875*4882a593Smuzhiyun p = &jfs_ip->i_dtroot;
2876*4882a593Smuzhiyun
2877*4882a593Smuzhiyun p->header.flag = DXD_INDEX | BT_ROOT | BT_LEAF;
2878*4882a593Smuzhiyun
2879*4882a593Smuzhiyun p->header.nextindex = 0;
2880*4882a593Smuzhiyun
2881*4882a593Smuzhiyun /* init freelist */
2882*4882a593Smuzhiyun fsi = 1;
2883*4882a593Smuzhiyun f = &p->slot[fsi];
2884*4882a593Smuzhiyun
2885*4882a593Smuzhiyun /* init data area of root */
2886*4882a593Smuzhiyun for (fsi++; fsi < DTROOTMAXSLOT; f++, fsi++)
2887*4882a593Smuzhiyun f->next = fsi;
2888*4882a593Smuzhiyun f->next = -1;
2889*4882a593Smuzhiyun
2890*4882a593Smuzhiyun p->header.freelist = 1;
2891*4882a593Smuzhiyun p->header.freecnt = 8;
2892*4882a593Smuzhiyun
2893*4882a593Smuzhiyun /* init '..' entry */
2894*4882a593Smuzhiyun p->header.idotdot = cpu_to_le32(idotdot);
2895*4882a593Smuzhiyun
2896*4882a593Smuzhiyun return;
2897*4882a593Smuzhiyun }
2898*4882a593Smuzhiyun
2899*4882a593Smuzhiyun /*
2900*4882a593Smuzhiyun * add_missing_indices()
2901*4882a593Smuzhiyun *
2902*4882a593Smuzhiyun * function: Fix dtree page in which one or more entries has an invalid index.
2903*4882a593Smuzhiyun * fsck.jfs should really fix this, but it currently does not.
2904*4882a593Smuzhiyun * Called from jfs_readdir when bad index is detected.
2905*4882a593Smuzhiyun */
add_missing_indices(struct inode * inode,s64 bn)2906*4882a593Smuzhiyun static void add_missing_indices(struct inode *inode, s64 bn)
2907*4882a593Smuzhiyun {
2908*4882a593Smuzhiyun struct ldtentry *d;
2909*4882a593Smuzhiyun struct dt_lock *dtlck;
2910*4882a593Smuzhiyun int i;
2911*4882a593Smuzhiyun uint index;
2912*4882a593Smuzhiyun struct lv *lv;
2913*4882a593Smuzhiyun struct metapage *mp;
2914*4882a593Smuzhiyun dtpage_t *p;
2915*4882a593Smuzhiyun int rc;
2916*4882a593Smuzhiyun s8 *stbl;
2917*4882a593Smuzhiyun tid_t tid;
2918*4882a593Smuzhiyun struct tlock *tlck;
2919*4882a593Smuzhiyun
2920*4882a593Smuzhiyun tid = txBegin(inode->i_sb, 0);
2921*4882a593Smuzhiyun
2922*4882a593Smuzhiyun DT_GETPAGE(inode, bn, mp, PSIZE, p, rc);
2923*4882a593Smuzhiyun
2924*4882a593Smuzhiyun if (rc) {
2925*4882a593Smuzhiyun printk(KERN_ERR "DT_GETPAGE failed!\n");
2926*4882a593Smuzhiyun goto end;
2927*4882a593Smuzhiyun }
2928*4882a593Smuzhiyun BT_MARK_DIRTY(mp, inode);
2929*4882a593Smuzhiyun
2930*4882a593Smuzhiyun ASSERT(p->header.flag & BT_LEAF);
2931*4882a593Smuzhiyun
2932*4882a593Smuzhiyun tlck = txLock(tid, inode, mp, tlckDTREE | tlckENTRY);
2933*4882a593Smuzhiyun if (BT_IS_ROOT(mp))
2934*4882a593Smuzhiyun tlck->type |= tlckBTROOT;
2935*4882a593Smuzhiyun
2936*4882a593Smuzhiyun dtlck = (struct dt_lock *) &tlck->lock;
2937*4882a593Smuzhiyun
2938*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
2939*4882a593Smuzhiyun for (i = 0; i < p->header.nextindex; i++) {
2940*4882a593Smuzhiyun d = (struct ldtentry *) &p->slot[stbl[i]];
2941*4882a593Smuzhiyun index = le32_to_cpu(d->index);
2942*4882a593Smuzhiyun if ((index < 2) || (index >= JFS_IP(inode)->next_index)) {
2943*4882a593Smuzhiyun d->index = cpu_to_le32(add_index(tid, inode, bn, i));
2944*4882a593Smuzhiyun if (dtlck->index >= dtlck->maxcnt)
2945*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
2946*4882a593Smuzhiyun lv = &dtlck->lv[dtlck->index];
2947*4882a593Smuzhiyun lv->offset = stbl[i];
2948*4882a593Smuzhiyun lv->length = 1;
2949*4882a593Smuzhiyun dtlck->index++;
2950*4882a593Smuzhiyun }
2951*4882a593Smuzhiyun }
2952*4882a593Smuzhiyun
2953*4882a593Smuzhiyun DT_PUTPAGE(mp);
2954*4882a593Smuzhiyun (void) txCommit(tid, 1, &inode, 0);
2955*4882a593Smuzhiyun end:
2956*4882a593Smuzhiyun txEnd(tid);
2957*4882a593Smuzhiyun }
2958*4882a593Smuzhiyun
2959*4882a593Smuzhiyun /*
2960*4882a593Smuzhiyun * Buffer to hold directory entry info while traversing a dtree page
2961*4882a593Smuzhiyun * before being fed to the filldir function
2962*4882a593Smuzhiyun */
2963*4882a593Smuzhiyun struct jfs_dirent {
2964*4882a593Smuzhiyun loff_t position;
2965*4882a593Smuzhiyun int ino;
2966*4882a593Smuzhiyun u16 name_len;
2967*4882a593Smuzhiyun char name[];
2968*4882a593Smuzhiyun };
2969*4882a593Smuzhiyun
2970*4882a593Smuzhiyun /*
2971*4882a593Smuzhiyun * function to determine next variable-sized jfs_dirent in buffer
2972*4882a593Smuzhiyun */
next_jfs_dirent(struct jfs_dirent * dirent)2973*4882a593Smuzhiyun static inline struct jfs_dirent *next_jfs_dirent(struct jfs_dirent *dirent)
2974*4882a593Smuzhiyun {
2975*4882a593Smuzhiyun return (struct jfs_dirent *)
2976*4882a593Smuzhiyun ((char *)dirent +
2977*4882a593Smuzhiyun ((sizeof (struct jfs_dirent) + dirent->name_len + 1 +
2978*4882a593Smuzhiyun sizeof (loff_t) - 1) &
2979*4882a593Smuzhiyun ~(sizeof (loff_t) - 1)));
2980*4882a593Smuzhiyun }
2981*4882a593Smuzhiyun
2982*4882a593Smuzhiyun /*
2983*4882a593Smuzhiyun * jfs_readdir()
2984*4882a593Smuzhiyun *
2985*4882a593Smuzhiyun * function: read directory entries sequentially
2986*4882a593Smuzhiyun * from the specified entry offset
2987*4882a593Smuzhiyun *
2988*4882a593Smuzhiyun * parameter:
2989*4882a593Smuzhiyun *
2990*4882a593Smuzhiyun * return: offset = (pn, index) of start entry
2991*4882a593Smuzhiyun * of next jfs_readdir()/dtRead()
2992*4882a593Smuzhiyun */
jfs_readdir(struct file * file,struct dir_context * ctx)2993*4882a593Smuzhiyun int jfs_readdir(struct file *file, struct dir_context *ctx)
2994*4882a593Smuzhiyun {
2995*4882a593Smuzhiyun struct inode *ip = file_inode(file);
2996*4882a593Smuzhiyun struct nls_table *codepage = JFS_SBI(ip->i_sb)->nls_tab;
2997*4882a593Smuzhiyun int rc = 0;
2998*4882a593Smuzhiyun loff_t dtpos; /* legacy OS/2 style position */
2999*4882a593Smuzhiyun struct dtoffset {
3000*4882a593Smuzhiyun s16 pn;
3001*4882a593Smuzhiyun s16 index;
3002*4882a593Smuzhiyun s32 unused;
3003*4882a593Smuzhiyun } *dtoffset = (struct dtoffset *) &dtpos;
3004*4882a593Smuzhiyun s64 bn;
3005*4882a593Smuzhiyun struct metapage *mp;
3006*4882a593Smuzhiyun dtpage_t *p;
3007*4882a593Smuzhiyun int index;
3008*4882a593Smuzhiyun s8 *stbl;
3009*4882a593Smuzhiyun struct btstack btstack;
3010*4882a593Smuzhiyun int i, next;
3011*4882a593Smuzhiyun struct ldtentry *d;
3012*4882a593Smuzhiyun struct dtslot *t;
3013*4882a593Smuzhiyun int d_namleft, len, outlen;
3014*4882a593Smuzhiyun unsigned long dirent_buf;
3015*4882a593Smuzhiyun char *name_ptr;
3016*4882a593Smuzhiyun u32 dir_index;
3017*4882a593Smuzhiyun int do_index = 0;
3018*4882a593Smuzhiyun uint loop_count = 0;
3019*4882a593Smuzhiyun struct jfs_dirent *jfs_dirent;
3020*4882a593Smuzhiyun int jfs_dirents;
3021*4882a593Smuzhiyun int overflow, fix_page, page_fixed = 0;
3022*4882a593Smuzhiyun static int unique_pos = 2; /* If we can't fix broken index */
3023*4882a593Smuzhiyun
3024*4882a593Smuzhiyun if (ctx->pos == DIREND)
3025*4882a593Smuzhiyun return 0;
3026*4882a593Smuzhiyun
3027*4882a593Smuzhiyun if (DO_INDEX(ip)) {
3028*4882a593Smuzhiyun /*
3029*4882a593Smuzhiyun * persistent index is stored in directory entries.
3030*4882a593Smuzhiyun * Special cases: 0 = .
3031*4882a593Smuzhiyun * 1 = ..
3032*4882a593Smuzhiyun * -1 = End of directory
3033*4882a593Smuzhiyun */
3034*4882a593Smuzhiyun do_index = 1;
3035*4882a593Smuzhiyun
3036*4882a593Smuzhiyun dir_index = (u32) ctx->pos;
3037*4882a593Smuzhiyun
3038*4882a593Smuzhiyun /*
3039*4882a593Smuzhiyun * NFSv4 reserves cookies 1 and 2 for . and .. so the value
3040*4882a593Smuzhiyun * we return to the vfs is one greater than the one we use
3041*4882a593Smuzhiyun * internally.
3042*4882a593Smuzhiyun */
3043*4882a593Smuzhiyun if (dir_index)
3044*4882a593Smuzhiyun dir_index--;
3045*4882a593Smuzhiyun
3046*4882a593Smuzhiyun if (dir_index > 1) {
3047*4882a593Smuzhiyun struct dir_table_slot dirtab_slot;
3048*4882a593Smuzhiyun
3049*4882a593Smuzhiyun if (dtEmpty(ip) ||
3050*4882a593Smuzhiyun (dir_index >= JFS_IP(ip)->next_index)) {
3051*4882a593Smuzhiyun /* Stale position. Directory has shrunk */
3052*4882a593Smuzhiyun ctx->pos = DIREND;
3053*4882a593Smuzhiyun return 0;
3054*4882a593Smuzhiyun }
3055*4882a593Smuzhiyun repeat:
3056*4882a593Smuzhiyun rc = read_index(ip, dir_index, &dirtab_slot);
3057*4882a593Smuzhiyun if (rc) {
3058*4882a593Smuzhiyun ctx->pos = DIREND;
3059*4882a593Smuzhiyun return rc;
3060*4882a593Smuzhiyun }
3061*4882a593Smuzhiyun if (dirtab_slot.flag == DIR_INDEX_FREE) {
3062*4882a593Smuzhiyun if (loop_count++ > JFS_IP(ip)->next_index) {
3063*4882a593Smuzhiyun jfs_err("jfs_readdir detected infinite loop!");
3064*4882a593Smuzhiyun ctx->pos = DIREND;
3065*4882a593Smuzhiyun return 0;
3066*4882a593Smuzhiyun }
3067*4882a593Smuzhiyun dir_index = le32_to_cpu(dirtab_slot.addr2);
3068*4882a593Smuzhiyun if (dir_index == -1) {
3069*4882a593Smuzhiyun ctx->pos = DIREND;
3070*4882a593Smuzhiyun return 0;
3071*4882a593Smuzhiyun }
3072*4882a593Smuzhiyun goto repeat;
3073*4882a593Smuzhiyun }
3074*4882a593Smuzhiyun bn = addressDTS(&dirtab_slot);
3075*4882a593Smuzhiyun index = dirtab_slot.slot;
3076*4882a593Smuzhiyun DT_GETPAGE(ip, bn, mp, PSIZE, p, rc);
3077*4882a593Smuzhiyun if (rc) {
3078*4882a593Smuzhiyun ctx->pos = DIREND;
3079*4882a593Smuzhiyun return 0;
3080*4882a593Smuzhiyun }
3081*4882a593Smuzhiyun if (p->header.flag & BT_INTERNAL) {
3082*4882a593Smuzhiyun jfs_err("jfs_readdir: bad index table");
3083*4882a593Smuzhiyun DT_PUTPAGE(mp);
3084*4882a593Smuzhiyun ctx->pos = DIREND;
3085*4882a593Smuzhiyun return 0;
3086*4882a593Smuzhiyun }
3087*4882a593Smuzhiyun } else {
3088*4882a593Smuzhiyun if (dir_index == 0) {
3089*4882a593Smuzhiyun /*
3090*4882a593Smuzhiyun * self "."
3091*4882a593Smuzhiyun */
3092*4882a593Smuzhiyun ctx->pos = 1;
3093*4882a593Smuzhiyun if (!dir_emit(ctx, ".", 1, ip->i_ino, DT_DIR))
3094*4882a593Smuzhiyun return 0;
3095*4882a593Smuzhiyun }
3096*4882a593Smuzhiyun /*
3097*4882a593Smuzhiyun * parent ".."
3098*4882a593Smuzhiyun */
3099*4882a593Smuzhiyun ctx->pos = 2;
3100*4882a593Smuzhiyun if (!dir_emit(ctx, "..", 2, PARENT(ip), DT_DIR))
3101*4882a593Smuzhiyun return 0;
3102*4882a593Smuzhiyun
3103*4882a593Smuzhiyun /*
3104*4882a593Smuzhiyun * Find first entry of left-most leaf
3105*4882a593Smuzhiyun */
3106*4882a593Smuzhiyun if (dtEmpty(ip)) {
3107*4882a593Smuzhiyun ctx->pos = DIREND;
3108*4882a593Smuzhiyun return 0;
3109*4882a593Smuzhiyun }
3110*4882a593Smuzhiyun
3111*4882a593Smuzhiyun if ((rc = dtReadFirst(ip, &btstack)))
3112*4882a593Smuzhiyun return rc;
3113*4882a593Smuzhiyun
3114*4882a593Smuzhiyun DT_GETSEARCH(ip, btstack.top, bn, mp, p, index);
3115*4882a593Smuzhiyun }
3116*4882a593Smuzhiyun } else {
3117*4882a593Smuzhiyun /*
3118*4882a593Smuzhiyun * Legacy filesystem - OS/2 & Linux JFS < 0.3.6
3119*4882a593Smuzhiyun *
3120*4882a593Smuzhiyun * pn = 0; index = 1: First entry "."
3121*4882a593Smuzhiyun * pn = 0; index = 2: Second entry ".."
3122*4882a593Smuzhiyun * pn > 0: Real entries, pn=1 -> leftmost page
3123*4882a593Smuzhiyun * pn = index = -1: No more entries
3124*4882a593Smuzhiyun */
3125*4882a593Smuzhiyun dtpos = ctx->pos;
3126*4882a593Smuzhiyun if (dtpos < 2) {
3127*4882a593Smuzhiyun /* build "." entry */
3128*4882a593Smuzhiyun ctx->pos = 1;
3129*4882a593Smuzhiyun if (!dir_emit(ctx, ".", 1, ip->i_ino, DT_DIR))
3130*4882a593Smuzhiyun return 0;
3131*4882a593Smuzhiyun dtoffset->index = 2;
3132*4882a593Smuzhiyun ctx->pos = dtpos;
3133*4882a593Smuzhiyun }
3134*4882a593Smuzhiyun
3135*4882a593Smuzhiyun if (dtoffset->pn == 0) {
3136*4882a593Smuzhiyun if (dtoffset->index == 2) {
3137*4882a593Smuzhiyun /* build ".." entry */
3138*4882a593Smuzhiyun if (!dir_emit(ctx, "..", 2, PARENT(ip), DT_DIR))
3139*4882a593Smuzhiyun return 0;
3140*4882a593Smuzhiyun } else {
3141*4882a593Smuzhiyun jfs_err("jfs_readdir called with invalid offset!");
3142*4882a593Smuzhiyun }
3143*4882a593Smuzhiyun dtoffset->pn = 1;
3144*4882a593Smuzhiyun dtoffset->index = 0;
3145*4882a593Smuzhiyun ctx->pos = dtpos;
3146*4882a593Smuzhiyun }
3147*4882a593Smuzhiyun
3148*4882a593Smuzhiyun if (dtEmpty(ip)) {
3149*4882a593Smuzhiyun ctx->pos = DIREND;
3150*4882a593Smuzhiyun return 0;
3151*4882a593Smuzhiyun }
3152*4882a593Smuzhiyun
3153*4882a593Smuzhiyun if ((rc = dtReadNext(ip, &ctx->pos, &btstack))) {
3154*4882a593Smuzhiyun jfs_err("jfs_readdir: unexpected rc = %d from dtReadNext",
3155*4882a593Smuzhiyun rc);
3156*4882a593Smuzhiyun ctx->pos = DIREND;
3157*4882a593Smuzhiyun return 0;
3158*4882a593Smuzhiyun }
3159*4882a593Smuzhiyun /* get start leaf page and index */
3160*4882a593Smuzhiyun DT_GETSEARCH(ip, btstack.top, bn, mp, p, index);
3161*4882a593Smuzhiyun
3162*4882a593Smuzhiyun /* offset beyond directory eof ? */
3163*4882a593Smuzhiyun if (bn < 0) {
3164*4882a593Smuzhiyun ctx->pos = DIREND;
3165*4882a593Smuzhiyun return 0;
3166*4882a593Smuzhiyun }
3167*4882a593Smuzhiyun }
3168*4882a593Smuzhiyun
3169*4882a593Smuzhiyun dirent_buf = __get_free_page(GFP_KERNEL);
3170*4882a593Smuzhiyun if (dirent_buf == 0) {
3171*4882a593Smuzhiyun DT_PUTPAGE(mp);
3172*4882a593Smuzhiyun jfs_warn("jfs_readdir: __get_free_page failed!");
3173*4882a593Smuzhiyun ctx->pos = DIREND;
3174*4882a593Smuzhiyun return -ENOMEM;
3175*4882a593Smuzhiyun }
3176*4882a593Smuzhiyun
3177*4882a593Smuzhiyun while (1) {
3178*4882a593Smuzhiyun jfs_dirent = (struct jfs_dirent *) dirent_buf;
3179*4882a593Smuzhiyun jfs_dirents = 0;
3180*4882a593Smuzhiyun overflow = fix_page = 0;
3181*4882a593Smuzhiyun
3182*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
3183*4882a593Smuzhiyun
3184*4882a593Smuzhiyun for (i = index; i < p->header.nextindex; i++) {
3185*4882a593Smuzhiyun d = (struct ldtentry *) & p->slot[stbl[i]];
3186*4882a593Smuzhiyun
3187*4882a593Smuzhiyun if (((long) jfs_dirent + d->namlen + 1) >
3188*4882a593Smuzhiyun (dirent_buf + PAGE_SIZE)) {
3189*4882a593Smuzhiyun /* DBCS codepages could overrun dirent_buf */
3190*4882a593Smuzhiyun index = i;
3191*4882a593Smuzhiyun overflow = 1;
3192*4882a593Smuzhiyun break;
3193*4882a593Smuzhiyun }
3194*4882a593Smuzhiyun
3195*4882a593Smuzhiyun d_namleft = d->namlen;
3196*4882a593Smuzhiyun name_ptr = jfs_dirent->name;
3197*4882a593Smuzhiyun jfs_dirent->ino = le32_to_cpu(d->inumber);
3198*4882a593Smuzhiyun
3199*4882a593Smuzhiyun if (do_index) {
3200*4882a593Smuzhiyun len = min(d_namleft, DTLHDRDATALEN);
3201*4882a593Smuzhiyun jfs_dirent->position = le32_to_cpu(d->index);
3202*4882a593Smuzhiyun /*
3203*4882a593Smuzhiyun * d->index should always be valid, but it
3204*4882a593Smuzhiyun * isn't. fsck.jfs doesn't create the
3205*4882a593Smuzhiyun * directory index for the lost+found
3206*4882a593Smuzhiyun * directory. Rather than let it go,
3207*4882a593Smuzhiyun * we can try to fix it.
3208*4882a593Smuzhiyun */
3209*4882a593Smuzhiyun if ((jfs_dirent->position < 2) ||
3210*4882a593Smuzhiyun (jfs_dirent->position >=
3211*4882a593Smuzhiyun JFS_IP(ip)->next_index)) {
3212*4882a593Smuzhiyun if (!page_fixed && !isReadOnly(ip)) {
3213*4882a593Smuzhiyun fix_page = 1;
3214*4882a593Smuzhiyun /*
3215*4882a593Smuzhiyun * setting overflow and setting
3216*4882a593Smuzhiyun * index to i will cause the
3217*4882a593Smuzhiyun * same page to be processed
3218*4882a593Smuzhiyun * again starting here
3219*4882a593Smuzhiyun */
3220*4882a593Smuzhiyun overflow = 1;
3221*4882a593Smuzhiyun index = i;
3222*4882a593Smuzhiyun break;
3223*4882a593Smuzhiyun }
3224*4882a593Smuzhiyun jfs_dirent->position = unique_pos++;
3225*4882a593Smuzhiyun }
3226*4882a593Smuzhiyun /*
3227*4882a593Smuzhiyun * We add 1 to the index because we may
3228*4882a593Smuzhiyun * use a value of 2 internally, and NFSv4
3229*4882a593Smuzhiyun * doesn't like that.
3230*4882a593Smuzhiyun */
3231*4882a593Smuzhiyun jfs_dirent->position++;
3232*4882a593Smuzhiyun } else {
3233*4882a593Smuzhiyun jfs_dirent->position = dtpos;
3234*4882a593Smuzhiyun len = min(d_namleft, DTLHDRDATALEN_LEGACY);
3235*4882a593Smuzhiyun }
3236*4882a593Smuzhiyun
3237*4882a593Smuzhiyun /* copy the name of head/only segment */
3238*4882a593Smuzhiyun outlen = jfs_strfromUCS_le(name_ptr, d->name, len,
3239*4882a593Smuzhiyun codepage);
3240*4882a593Smuzhiyun jfs_dirent->name_len = outlen;
3241*4882a593Smuzhiyun
3242*4882a593Smuzhiyun /* copy name in the additional segment(s) */
3243*4882a593Smuzhiyun next = d->next;
3244*4882a593Smuzhiyun while (next >= 0) {
3245*4882a593Smuzhiyun t = (struct dtslot *) & p->slot[next];
3246*4882a593Smuzhiyun name_ptr += outlen;
3247*4882a593Smuzhiyun d_namleft -= len;
3248*4882a593Smuzhiyun /* Sanity Check */
3249*4882a593Smuzhiyun if (d_namleft == 0) {
3250*4882a593Smuzhiyun jfs_error(ip->i_sb,
3251*4882a593Smuzhiyun "JFS:Dtree error: ino = %ld, bn=%lld, index = %d\n",
3252*4882a593Smuzhiyun (long)ip->i_ino,
3253*4882a593Smuzhiyun (long long)bn,
3254*4882a593Smuzhiyun i);
3255*4882a593Smuzhiyun goto skip_one;
3256*4882a593Smuzhiyun }
3257*4882a593Smuzhiyun len = min(d_namleft, DTSLOTDATALEN);
3258*4882a593Smuzhiyun outlen = jfs_strfromUCS_le(name_ptr, t->name,
3259*4882a593Smuzhiyun len, codepage);
3260*4882a593Smuzhiyun jfs_dirent->name_len += outlen;
3261*4882a593Smuzhiyun
3262*4882a593Smuzhiyun next = t->next;
3263*4882a593Smuzhiyun }
3264*4882a593Smuzhiyun
3265*4882a593Smuzhiyun jfs_dirents++;
3266*4882a593Smuzhiyun jfs_dirent = next_jfs_dirent(jfs_dirent);
3267*4882a593Smuzhiyun skip_one:
3268*4882a593Smuzhiyun if (!do_index)
3269*4882a593Smuzhiyun dtoffset->index++;
3270*4882a593Smuzhiyun }
3271*4882a593Smuzhiyun
3272*4882a593Smuzhiyun if (!overflow) {
3273*4882a593Smuzhiyun /* Point to next leaf page */
3274*4882a593Smuzhiyun if (p->header.flag & BT_ROOT)
3275*4882a593Smuzhiyun bn = 0;
3276*4882a593Smuzhiyun else {
3277*4882a593Smuzhiyun bn = le64_to_cpu(p->header.next);
3278*4882a593Smuzhiyun index = 0;
3279*4882a593Smuzhiyun /* update offset (pn:index) for new page */
3280*4882a593Smuzhiyun if (!do_index) {
3281*4882a593Smuzhiyun dtoffset->pn++;
3282*4882a593Smuzhiyun dtoffset->index = 0;
3283*4882a593Smuzhiyun }
3284*4882a593Smuzhiyun }
3285*4882a593Smuzhiyun page_fixed = 0;
3286*4882a593Smuzhiyun }
3287*4882a593Smuzhiyun
3288*4882a593Smuzhiyun /* unpin previous leaf page */
3289*4882a593Smuzhiyun DT_PUTPAGE(mp);
3290*4882a593Smuzhiyun
3291*4882a593Smuzhiyun jfs_dirent = (struct jfs_dirent *) dirent_buf;
3292*4882a593Smuzhiyun while (jfs_dirents--) {
3293*4882a593Smuzhiyun ctx->pos = jfs_dirent->position;
3294*4882a593Smuzhiyun if (!dir_emit(ctx, jfs_dirent->name,
3295*4882a593Smuzhiyun jfs_dirent->name_len,
3296*4882a593Smuzhiyun jfs_dirent->ino, DT_UNKNOWN))
3297*4882a593Smuzhiyun goto out;
3298*4882a593Smuzhiyun jfs_dirent = next_jfs_dirent(jfs_dirent);
3299*4882a593Smuzhiyun }
3300*4882a593Smuzhiyun
3301*4882a593Smuzhiyun if (fix_page) {
3302*4882a593Smuzhiyun add_missing_indices(ip, bn);
3303*4882a593Smuzhiyun page_fixed = 1;
3304*4882a593Smuzhiyun }
3305*4882a593Smuzhiyun
3306*4882a593Smuzhiyun if (!overflow && (bn == 0)) {
3307*4882a593Smuzhiyun ctx->pos = DIREND;
3308*4882a593Smuzhiyun break;
3309*4882a593Smuzhiyun }
3310*4882a593Smuzhiyun
3311*4882a593Smuzhiyun DT_GETPAGE(ip, bn, mp, PSIZE, p, rc);
3312*4882a593Smuzhiyun if (rc) {
3313*4882a593Smuzhiyun free_page(dirent_buf);
3314*4882a593Smuzhiyun return rc;
3315*4882a593Smuzhiyun }
3316*4882a593Smuzhiyun }
3317*4882a593Smuzhiyun
3318*4882a593Smuzhiyun out:
3319*4882a593Smuzhiyun free_page(dirent_buf);
3320*4882a593Smuzhiyun
3321*4882a593Smuzhiyun return rc;
3322*4882a593Smuzhiyun }
3323*4882a593Smuzhiyun
3324*4882a593Smuzhiyun
3325*4882a593Smuzhiyun /*
3326*4882a593Smuzhiyun * dtReadFirst()
3327*4882a593Smuzhiyun *
3328*4882a593Smuzhiyun * function: get the leftmost page of the directory
3329*4882a593Smuzhiyun */
dtReadFirst(struct inode * ip,struct btstack * btstack)3330*4882a593Smuzhiyun static int dtReadFirst(struct inode *ip, struct btstack * btstack)
3331*4882a593Smuzhiyun {
3332*4882a593Smuzhiyun int rc = 0;
3333*4882a593Smuzhiyun s64 bn;
3334*4882a593Smuzhiyun int psize = 288; /* initial in-line directory */
3335*4882a593Smuzhiyun struct metapage *mp;
3336*4882a593Smuzhiyun dtpage_t *p;
3337*4882a593Smuzhiyun s8 *stbl;
3338*4882a593Smuzhiyun struct btframe *btsp;
3339*4882a593Smuzhiyun pxd_t *xd;
3340*4882a593Smuzhiyun
3341*4882a593Smuzhiyun BT_CLR(btstack); /* reset stack */
3342*4882a593Smuzhiyun
3343*4882a593Smuzhiyun /*
3344*4882a593Smuzhiyun * descend leftmost path of the tree
3345*4882a593Smuzhiyun *
3346*4882a593Smuzhiyun * by convention, root bn = 0.
3347*4882a593Smuzhiyun */
3348*4882a593Smuzhiyun for (bn = 0;;) {
3349*4882a593Smuzhiyun DT_GETPAGE(ip, bn, mp, psize, p, rc);
3350*4882a593Smuzhiyun if (rc)
3351*4882a593Smuzhiyun return rc;
3352*4882a593Smuzhiyun
3353*4882a593Smuzhiyun /*
3354*4882a593Smuzhiyun * leftmost leaf page
3355*4882a593Smuzhiyun */
3356*4882a593Smuzhiyun if (p->header.flag & BT_LEAF) {
3357*4882a593Smuzhiyun /* return leftmost entry */
3358*4882a593Smuzhiyun btsp = btstack->top;
3359*4882a593Smuzhiyun btsp->bn = bn;
3360*4882a593Smuzhiyun btsp->index = 0;
3361*4882a593Smuzhiyun btsp->mp = mp;
3362*4882a593Smuzhiyun
3363*4882a593Smuzhiyun return 0;
3364*4882a593Smuzhiyun }
3365*4882a593Smuzhiyun
3366*4882a593Smuzhiyun /*
3367*4882a593Smuzhiyun * descend down to leftmost child page
3368*4882a593Smuzhiyun */
3369*4882a593Smuzhiyun if (BT_STACK_FULL(btstack)) {
3370*4882a593Smuzhiyun DT_PUTPAGE(mp);
3371*4882a593Smuzhiyun jfs_error(ip->i_sb, "btstack overrun\n");
3372*4882a593Smuzhiyun BT_STACK_DUMP(btstack);
3373*4882a593Smuzhiyun return -EIO;
3374*4882a593Smuzhiyun }
3375*4882a593Smuzhiyun /* push (bn, index) of the parent page/entry */
3376*4882a593Smuzhiyun BT_PUSH(btstack, bn, 0);
3377*4882a593Smuzhiyun
3378*4882a593Smuzhiyun /* get the leftmost entry */
3379*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
3380*4882a593Smuzhiyun xd = (pxd_t *) & p->slot[stbl[0]];
3381*4882a593Smuzhiyun
3382*4882a593Smuzhiyun /* get the child page block address */
3383*4882a593Smuzhiyun bn = addressPXD(xd);
3384*4882a593Smuzhiyun psize = lengthPXD(xd) << JFS_SBI(ip->i_sb)->l2bsize;
3385*4882a593Smuzhiyun
3386*4882a593Smuzhiyun /* unpin the parent page */
3387*4882a593Smuzhiyun DT_PUTPAGE(mp);
3388*4882a593Smuzhiyun }
3389*4882a593Smuzhiyun }
3390*4882a593Smuzhiyun
3391*4882a593Smuzhiyun
3392*4882a593Smuzhiyun /*
3393*4882a593Smuzhiyun * dtReadNext()
3394*4882a593Smuzhiyun *
3395*4882a593Smuzhiyun * function: get the page of the specified offset (pn:index)
3396*4882a593Smuzhiyun *
3397*4882a593Smuzhiyun * return: if (offset > eof), bn = -1;
3398*4882a593Smuzhiyun *
3399*4882a593Smuzhiyun * note: if index > nextindex of the target leaf page,
3400*4882a593Smuzhiyun * start with 1st entry of next leaf page;
3401*4882a593Smuzhiyun */
dtReadNext(struct inode * ip,loff_t * offset,struct btstack * btstack)3402*4882a593Smuzhiyun static int dtReadNext(struct inode *ip, loff_t * offset,
3403*4882a593Smuzhiyun struct btstack * btstack)
3404*4882a593Smuzhiyun {
3405*4882a593Smuzhiyun int rc = 0;
3406*4882a593Smuzhiyun struct dtoffset {
3407*4882a593Smuzhiyun s16 pn;
3408*4882a593Smuzhiyun s16 index;
3409*4882a593Smuzhiyun s32 unused;
3410*4882a593Smuzhiyun } *dtoffset = (struct dtoffset *) offset;
3411*4882a593Smuzhiyun s64 bn;
3412*4882a593Smuzhiyun struct metapage *mp;
3413*4882a593Smuzhiyun dtpage_t *p;
3414*4882a593Smuzhiyun int index;
3415*4882a593Smuzhiyun int pn;
3416*4882a593Smuzhiyun s8 *stbl;
3417*4882a593Smuzhiyun struct btframe *btsp, *parent;
3418*4882a593Smuzhiyun pxd_t *xd;
3419*4882a593Smuzhiyun
3420*4882a593Smuzhiyun /*
3421*4882a593Smuzhiyun * get leftmost leaf page pinned
3422*4882a593Smuzhiyun */
3423*4882a593Smuzhiyun if ((rc = dtReadFirst(ip, btstack)))
3424*4882a593Smuzhiyun return rc;
3425*4882a593Smuzhiyun
3426*4882a593Smuzhiyun /* get leaf page */
3427*4882a593Smuzhiyun DT_GETSEARCH(ip, btstack->top, bn, mp, p, index);
3428*4882a593Smuzhiyun
3429*4882a593Smuzhiyun /* get the start offset (pn:index) */
3430*4882a593Smuzhiyun pn = dtoffset->pn - 1; /* Now pn = 0 represents leftmost leaf */
3431*4882a593Smuzhiyun index = dtoffset->index;
3432*4882a593Smuzhiyun
3433*4882a593Smuzhiyun /* start at leftmost page ? */
3434*4882a593Smuzhiyun if (pn == 0) {
3435*4882a593Smuzhiyun /* offset beyond eof ? */
3436*4882a593Smuzhiyun if (index < p->header.nextindex)
3437*4882a593Smuzhiyun goto out;
3438*4882a593Smuzhiyun
3439*4882a593Smuzhiyun if (p->header.flag & BT_ROOT) {
3440*4882a593Smuzhiyun bn = -1;
3441*4882a593Smuzhiyun goto out;
3442*4882a593Smuzhiyun }
3443*4882a593Smuzhiyun
3444*4882a593Smuzhiyun /* start with 1st entry of next leaf page */
3445*4882a593Smuzhiyun dtoffset->pn++;
3446*4882a593Smuzhiyun dtoffset->index = index = 0;
3447*4882a593Smuzhiyun goto a;
3448*4882a593Smuzhiyun }
3449*4882a593Smuzhiyun
3450*4882a593Smuzhiyun /* start at non-leftmost page: scan parent pages for large pn */
3451*4882a593Smuzhiyun if (p->header.flag & BT_ROOT) {
3452*4882a593Smuzhiyun bn = -1;
3453*4882a593Smuzhiyun goto out;
3454*4882a593Smuzhiyun }
3455*4882a593Smuzhiyun
3456*4882a593Smuzhiyun /* start after next leaf page ? */
3457*4882a593Smuzhiyun if (pn > 1)
3458*4882a593Smuzhiyun goto b;
3459*4882a593Smuzhiyun
3460*4882a593Smuzhiyun /* get leaf page pn = 1 */
3461*4882a593Smuzhiyun a:
3462*4882a593Smuzhiyun bn = le64_to_cpu(p->header.next);
3463*4882a593Smuzhiyun
3464*4882a593Smuzhiyun /* unpin leaf page */
3465*4882a593Smuzhiyun DT_PUTPAGE(mp);
3466*4882a593Smuzhiyun
3467*4882a593Smuzhiyun /* offset beyond eof ? */
3468*4882a593Smuzhiyun if (bn == 0) {
3469*4882a593Smuzhiyun bn = -1;
3470*4882a593Smuzhiyun goto out;
3471*4882a593Smuzhiyun }
3472*4882a593Smuzhiyun
3473*4882a593Smuzhiyun goto c;
3474*4882a593Smuzhiyun
3475*4882a593Smuzhiyun /*
3476*4882a593Smuzhiyun * scan last internal page level to get target leaf page
3477*4882a593Smuzhiyun */
3478*4882a593Smuzhiyun b:
3479*4882a593Smuzhiyun /* unpin leftmost leaf page */
3480*4882a593Smuzhiyun DT_PUTPAGE(mp);
3481*4882a593Smuzhiyun
3482*4882a593Smuzhiyun /* get left most parent page */
3483*4882a593Smuzhiyun btsp = btstack->top;
3484*4882a593Smuzhiyun parent = btsp - 1;
3485*4882a593Smuzhiyun bn = parent->bn;
3486*4882a593Smuzhiyun DT_GETPAGE(ip, bn, mp, PSIZE, p, rc);
3487*4882a593Smuzhiyun if (rc)
3488*4882a593Smuzhiyun return rc;
3489*4882a593Smuzhiyun
3490*4882a593Smuzhiyun /* scan parent pages at last internal page level */
3491*4882a593Smuzhiyun while (pn >= p->header.nextindex) {
3492*4882a593Smuzhiyun pn -= p->header.nextindex;
3493*4882a593Smuzhiyun
3494*4882a593Smuzhiyun /* get next parent page address */
3495*4882a593Smuzhiyun bn = le64_to_cpu(p->header.next);
3496*4882a593Smuzhiyun
3497*4882a593Smuzhiyun /* unpin current parent page */
3498*4882a593Smuzhiyun DT_PUTPAGE(mp);
3499*4882a593Smuzhiyun
3500*4882a593Smuzhiyun /* offset beyond eof ? */
3501*4882a593Smuzhiyun if (bn == 0) {
3502*4882a593Smuzhiyun bn = -1;
3503*4882a593Smuzhiyun goto out;
3504*4882a593Smuzhiyun }
3505*4882a593Smuzhiyun
3506*4882a593Smuzhiyun /* get next parent page */
3507*4882a593Smuzhiyun DT_GETPAGE(ip, bn, mp, PSIZE, p, rc);
3508*4882a593Smuzhiyun if (rc)
3509*4882a593Smuzhiyun return rc;
3510*4882a593Smuzhiyun
3511*4882a593Smuzhiyun /* update parent page stack frame */
3512*4882a593Smuzhiyun parent->bn = bn;
3513*4882a593Smuzhiyun }
3514*4882a593Smuzhiyun
3515*4882a593Smuzhiyun /* get leaf page address */
3516*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
3517*4882a593Smuzhiyun xd = (pxd_t *) & p->slot[stbl[pn]];
3518*4882a593Smuzhiyun bn = addressPXD(xd);
3519*4882a593Smuzhiyun
3520*4882a593Smuzhiyun /* unpin parent page */
3521*4882a593Smuzhiyun DT_PUTPAGE(mp);
3522*4882a593Smuzhiyun
3523*4882a593Smuzhiyun /*
3524*4882a593Smuzhiyun * get target leaf page
3525*4882a593Smuzhiyun */
3526*4882a593Smuzhiyun c:
3527*4882a593Smuzhiyun DT_GETPAGE(ip, bn, mp, PSIZE, p, rc);
3528*4882a593Smuzhiyun if (rc)
3529*4882a593Smuzhiyun return rc;
3530*4882a593Smuzhiyun
3531*4882a593Smuzhiyun /*
3532*4882a593Smuzhiyun * leaf page has been completed:
3533*4882a593Smuzhiyun * start with 1st entry of next leaf page
3534*4882a593Smuzhiyun */
3535*4882a593Smuzhiyun if (index >= p->header.nextindex) {
3536*4882a593Smuzhiyun bn = le64_to_cpu(p->header.next);
3537*4882a593Smuzhiyun
3538*4882a593Smuzhiyun /* unpin leaf page */
3539*4882a593Smuzhiyun DT_PUTPAGE(mp);
3540*4882a593Smuzhiyun
3541*4882a593Smuzhiyun /* offset beyond eof ? */
3542*4882a593Smuzhiyun if (bn == 0) {
3543*4882a593Smuzhiyun bn = -1;
3544*4882a593Smuzhiyun goto out;
3545*4882a593Smuzhiyun }
3546*4882a593Smuzhiyun
3547*4882a593Smuzhiyun /* get next leaf page */
3548*4882a593Smuzhiyun DT_GETPAGE(ip, bn, mp, PSIZE, p, rc);
3549*4882a593Smuzhiyun if (rc)
3550*4882a593Smuzhiyun return rc;
3551*4882a593Smuzhiyun
3552*4882a593Smuzhiyun /* start with 1st entry of next leaf page */
3553*4882a593Smuzhiyun dtoffset->pn++;
3554*4882a593Smuzhiyun dtoffset->index = 0;
3555*4882a593Smuzhiyun }
3556*4882a593Smuzhiyun
3557*4882a593Smuzhiyun out:
3558*4882a593Smuzhiyun /* return target leaf page pinned */
3559*4882a593Smuzhiyun btsp = btstack->top;
3560*4882a593Smuzhiyun btsp->bn = bn;
3561*4882a593Smuzhiyun btsp->index = dtoffset->index;
3562*4882a593Smuzhiyun btsp->mp = mp;
3563*4882a593Smuzhiyun
3564*4882a593Smuzhiyun return 0;
3565*4882a593Smuzhiyun }
3566*4882a593Smuzhiyun
3567*4882a593Smuzhiyun
3568*4882a593Smuzhiyun /*
3569*4882a593Smuzhiyun * dtCompare()
3570*4882a593Smuzhiyun *
3571*4882a593Smuzhiyun * function: compare search key with an internal entry
3572*4882a593Smuzhiyun *
3573*4882a593Smuzhiyun * return:
3574*4882a593Smuzhiyun * < 0 if k is < record
3575*4882a593Smuzhiyun * = 0 if k is = record
3576*4882a593Smuzhiyun * > 0 if k is > record
3577*4882a593Smuzhiyun */
dtCompare(struct component_name * key,dtpage_t * p,int si)3578*4882a593Smuzhiyun static int dtCompare(struct component_name * key, /* search key */
3579*4882a593Smuzhiyun dtpage_t * p, /* directory page */
3580*4882a593Smuzhiyun int si)
3581*4882a593Smuzhiyun { /* entry slot index */
3582*4882a593Smuzhiyun wchar_t *kname;
3583*4882a593Smuzhiyun __le16 *name;
3584*4882a593Smuzhiyun int klen, namlen, len, rc;
3585*4882a593Smuzhiyun struct idtentry *ih;
3586*4882a593Smuzhiyun struct dtslot *t;
3587*4882a593Smuzhiyun
3588*4882a593Smuzhiyun /*
3589*4882a593Smuzhiyun * force the left-most key on internal pages, at any level of
3590*4882a593Smuzhiyun * the tree, to be less than any search key.
3591*4882a593Smuzhiyun * this obviates having to update the leftmost key on an internal
3592*4882a593Smuzhiyun * page when the user inserts a new key in the tree smaller than
3593*4882a593Smuzhiyun * anything that has been stored.
3594*4882a593Smuzhiyun *
3595*4882a593Smuzhiyun * (? if/when dtSearch() narrows down to 1st entry (index = 0),
3596*4882a593Smuzhiyun * at any internal page at any level of the tree,
3597*4882a593Smuzhiyun * it descends to child of the entry anyway -
3598*4882a593Smuzhiyun * ? make the entry as min size dummy entry)
3599*4882a593Smuzhiyun *
3600*4882a593Smuzhiyun * if (e->index == 0 && h->prevpg == P_INVALID && !(h->flags & BT_LEAF))
3601*4882a593Smuzhiyun * return (1);
3602*4882a593Smuzhiyun */
3603*4882a593Smuzhiyun
3604*4882a593Smuzhiyun kname = key->name;
3605*4882a593Smuzhiyun klen = key->namlen;
3606*4882a593Smuzhiyun
3607*4882a593Smuzhiyun ih = (struct idtentry *) & p->slot[si];
3608*4882a593Smuzhiyun si = ih->next;
3609*4882a593Smuzhiyun name = ih->name;
3610*4882a593Smuzhiyun namlen = ih->namlen;
3611*4882a593Smuzhiyun len = min(namlen, DTIHDRDATALEN);
3612*4882a593Smuzhiyun
3613*4882a593Smuzhiyun /* compare with head/only segment */
3614*4882a593Smuzhiyun len = min(klen, len);
3615*4882a593Smuzhiyun if ((rc = UniStrncmp_le(kname, name, len)))
3616*4882a593Smuzhiyun return rc;
3617*4882a593Smuzhiyun
3618*4882a593Smuzhiyun klen -= len;
3619*4882a593Smuzhiyun namlen -= len;
3620*4882a593Smuzhiyun
3621*4882a593Smuzhiyun /* compare with additional segment(s) */
3622*4882a593Smuzhiyun kname += len;
3623*4882a593Smuzhiyun while (klen > 0 && namlen > 0) {
3624*4882a593Smuzhiyun /* compare with next name segment */
3625*4882a593Smuzhiyun t = (struct dtslot *) & p->slot[si];
3626*4882a593Smuzhiyun len = min(namlen, DTSLOTDATALEN);
3627*4882a593Smuzhiyun len = min(klen, len);
3628*4882a593Smuzhiyun name = t->name;
3629*4882a593Smuzhiyun if ((rc = UniStrncmp_le(kname, name, len)))
3630*4882a593Smuzhiyun return rc;
3631*4882a593Smuzhiyun
3632*4882a593Smuzhiyun klen -= len;
3633*4882a593Smuzhiyun namlen -= len;
3634*4882a593Smuzhiyun kname += len;
3635*4882a593Smuzhiyun si = t->next;
3636*4882a593Smuzhiyun }
3637*4882a593Smuzhiyun
3638*4882a593Smuzhiyun return (klen - namlen);
3639*4882a593Smuzhiyun }
3640*4882a593Smuzhiyun
3641*4882a593Smuzhiyun
3642*4882a593Smuzhiyun
3643*4882a593Smuzhiyun
3644*4882a593Smuzhiyun /*
3645*4882a593Smuzhiyun * ciCompare()
3646*4882a593Smuzhiyun *
3647*4882a593Smuzhiyun * function: compare search key with an (leaf/internal) entry
3648*4882a593Smuzhiyun *
3649*4882a593Smuzhiyun * return:
3650*4882a593Smuzhiyun * < 0 if k is < record
3651*4882a593Smuzhiyun * = 0 if k is = record
3652*4882a593Smuzhiyun * > 0 if k is > record
3653*4882a593Smuzhiyun */
ciCompare(struct component_name * key,dtpage_t * p,int si,int flag)3654*4882a593Smuzhiyun static int ciCompare(struct component_name * key, /* search key */
3655*4882a593Smuzhiyun dtpage_t * p, /* directory page */
3656*4882a593Smuzhiyun int si, /* entry slot index */
3657*4882a593Smuzhiyun int flag)
3658*4882a593Smuzhiyun {
3659*4882a593Smuzhiyun wchar_t *kname, x;
3660*4882a593Smuzhiyun __le16 *name;
3661*4882a593Smuzhiyun int klen, namlen, len, rc;
3662*4882a593Smuzhiyun struct ldtentry *lh;
3663*4882a593Smuzhiyun struct idtentry *ih;
3664*4882a593Smuzhiyun struct dtslot *t;
3665*4882a593Smuzhiyun int i;
3666*4882a593Smuzhiyun
3667*4882a593Smuzhiyun /*
3668*4882a593Smuzhiyun * force the left-most key on internal pages, at any level of
3669*4882a593Smuzhiyun * the tree, to be less than any search key.
3670*4882a593Smuzhiyun * this obviates having to update the leftmost key on an internal
3671*4882a593Smuzhiyun * page when the user inserts a new key in the tree smaller than
3672*4882a593Smuzhiyun * anything that has been stored.
3673*4882a593Smuzhiyun *
3674*4882a593Smuzhiyun * (? if/when dtSearch() narrows down to 1st entry (index = 0),
3675*4882a593Smuzhiyun * at any internal page at any level of the tree,
3676*4882a593Smuzhiyun * it descends to child of the entry anyway -
3677*4882a593Smuzhiyun * ? make the entry as min size dummy entry)
3678*4882a593Smuzhiyun *
3679*4882a593Smuzhiyun * if (e->index == 0 && h->prevpg == P_INVALID && !(h->flags & BT_LEAF))
3680*4882a593Smuzhiyun * return (1);
3681*4882a593Smuzhiyun */
3682*4882a593Smuzhiyun
3683*4882a593Smuzhiyun kname = key->name;
3684*4882a593Smuzhiyun klen = key->namlen;
3685*4882a593Smuzhiyun
3686*4882a593Smuzhiyun /*
3687*4882a593Smuzhiyun * leaf page entry
3688*4882a593Smuzhiyun */
3689*4882a593Smuzhiyun if (p->header.flag & BT_LEAF) {
3690*4882a593Smuzhiyun lh = (struct ldtentry *) & p->slot[si];
3691*4882a593Smuzhiyun si = lh->next;
3692*4882a593Smuzhiyun name = lh->name;
3693*4882a593Smuzhiyun namlen = lh->namlen;
3694*4882a593Smuzhiyun if (flag & JFS_DIR_INDEX)
3695*4882a593Smuzhiyun len = min(namlen, DTLHDRDATALEN);
3696*4882a593Smuzhiyun else
3697*4882a593Smuzhiyun len = min(namlen, DTLHDRDATALEN_LEGACY);
3698*4882a593Smuzhiyun }
3699*4882a593Smuzhiyun /*
3700*4882a593Smuzhiyun * internal page entry
3701*4882a593Smuzhiyun */
3702*4882a593Smuzhiyun else {
3703*4882a593Smuzhiyun ih = (struct idtentry *) & p->slot[si];
3704*4882a593Smuzhiyun si = ih->next;
3705*4882a593Smuzhiyun name = ih->name;
3706*4882a593Smuzhiyun namlen = ih->namlen;
3707*4882a593Smuzhiyun len = min(namlen, DTIHDRDATALEN);
3708*4882a593Smuzhiyun }
3709*4882a593Smuzhiyun
3710*4882a593Smuzhiyun /* compare with head/only segment */
3711*4882a593Smuzhiyun len = min(klen, len);
3712*4882a593Smuzhiyun for (i = 0; i < len; i++, kname++, name++) {
3713*4882a593Smuzhiyun /* only uppercase if case-insensitive support is on */
3714*4882a593Smuzhiyun if ((flag & JFS_OS2) == JFS_OS2)
3715*4882a593Smuzhiyun x = UniToupper(le16_to_cpu(*name));
3716*4882a593Smuzhiyun else
3717*4882a593Smuzhiyun x = le16_to_cpu(*name);
3718*4882a593Smuzhiyun if ((rc = *kname - x))
3719*4882a593Smuzhiyun return rc;
3720*4882a593Smuzhiyun }
3721*4882a593Smuzhiyun
3722*4882a593Smuzhiyun klen -= len;
3723*4882a593Smuzhiyun namlen -= len;
3724*4882a593Smuzhiyun
3725*4882a593Smuzhiyun /* compare with additional segment(s) */
3726*4882a593Smuzhiyun while (klen > 0 && namlen > 0) {
3727*4882a593Smuzhiyun /* compare with next name segment */
3728*4882a593Smuzhiyun t = (struct dtslot *) & p->slot[si];
3729*4882a593Smuzhiyun len = min(namlen, DTSLOTDATALEN);
3730*4882a593Smuzhiyun len = min(klen, len);
3731*4882a593Smuzhiyun name = t->name;
3732*4882a593Smuzhiyun for (i = 0; i < len; i++, kname++, name++) {
3733*4882a593Smuzhiyun /* only uppercase if case-insensitive support is on */
3734*4882a593Smuzhiyun if ((flag & JFS_OS2) == JFS_OS2)
3735*4882a593Smuzhiyun x = UniToupper(le16_to_cpu(*name));
3736*4882a593Smuzhiyun else
3737*4882a593Smuzhiyun x = le16_to_cpu(*name);
3738*4882a593Smuzhiyun
3739*4882a593Smuzhiyun if ((rc = *kname - x))
3740*4882a593Smuzhiyun return rc;
3741*4882a593Smuzhiyun }
3742*4882a593Smuzhiyun
3743*4882a593Smuzhiyun klen -= len;
3744*4882a593Smuzhiyun namlen -= len;
3745*4882a593Smuzhiyun si = t->next;
3746*4882a593Smuzhiyun }
3747*4882a593Smuzhiyun
3748*4882a593Smuzhiyun return (klen - namlen);
3749*4882a593Smuzhiyun }
3750*4882a593Smuzhiyun
3751*4882a593Smuzhiyun
3752*4882a593Smuzhiyun /*
3753*4882a593Smuzhiyun * ciGetLeafPrefixKey()
3754*4882a593Smuzhiyun *
3755*4882a593Smuzhiyun * function: compute prefix of suffix compression
3756*4882a593Smuzhiyun * from two adjacent leaf entries
3757*4882a593Smuzhiyun * across page boundary
3758*4882a593Smuzhiyun *
3759*4882a593Smuzhiyun * return: non-zero on error
3760*4882a593Smuzhiyun *
3761*4882a593Smuzhiyun */
ciGetLeafPrefixKey(dtpage_t * lp,int li,dtpage_t * rp,int ri,struct component_name * key,int flag)3762*4882a593Smuzhiyun static int ciGetLeafPrefixKey(dtpage_t * lp, int li, dtpage_t * rp,
3763*4882a593Smuzhiyun int ri, struct component_name * key, int flag)
3764*4882a593Smuzhiyun {
3765*4882a593Smuzhiyun int klen, namlen;
3766*4882a593Smuzhiyun wchar_t *pl, *pr, *kname;
3767*4882a593Smuzhiyun struct component_name lkey;
3768*4882a593Smuzhiyun struct component_name rkey;
3769*4882a593Smuzhiyun
3770*4882a593Smuzhiyun lkey.name = kmalloc_array(JFS_NAME_MAX + 1, sizeof(wchar_t),
3771*4882a593Smuzhiyun GFP_KERNEL);
3772*4882a593Smuzhiyun if (lkey.name == NULL)
3773*4882a593Smuzhiyun return -ENOMEM;
3774*4882a593Smuzhiyun
3775*4882a593Smuzhiyun rkey.name = kmalloc_array(JFS_NAME_MAX + 1, sizeof(wchar_t),
3776*4882a593Smuzhiyun GFP_KERNEL);
3777*4882a593Smuzhiyun if (rkey.name == NULL) {
3778*4882a593Smuzhiyun kfree(lkey.name);
3779*4882a593Smuzhiyun return -ENOMEM;
3780*4882a593Smuzhiyun }
3781*4882a593Smuzhiyun
3782*4882a593Smuzhiyun /* get left and right key */
3783*4882a593Smuzhiyun dtGetKey(lp, li, &lkey, flag);
3784*4882a593Smuzhiyun lkey.name[lkey.namlen] = 0;
3785*4882a593Smuzhiyun
3786*4882a593Smuzhiyun if ((flag & JFS_OS2) == JFS_OS2)
3787*4882a593Smuzhiyun ciToUpper(&lkey);
3788*4882a593Smuzhiyun
3789*4882a593Smuzhiyun dtGetKey(rp, ri, &rkey, flag);
3790*4882a593Smuzhiyun rkey.name[rkey.namlen] = 0;
3791*4882a593Smuzhiyun
3792*4882a593Smuzhiyun
3793*4882a593Smuzhiyun if ((flag & JFS_OS2) == JFS_OS2)
3794*4882a593Smuzhiyun ciToUpper(&rkey);
3795*4882a593Smuzhiyun
3796*4882a593Smuzhiyun /* compute prefix */
3797*4882a593Smuzhiyun klen = 0;
3798*4882a593Smuzhiyun kname = key->name;
3799*4882a593Smuzhiyun namlen = min(lkey.namlen, rkey.namlen);
3800*4882a593Smuzhiyun for (pl = lkey.name, pr = rkey.name;
3801*4882a593Smuzhiyun namlen; pl++, pr++, namlen--, klen++, kname++) {
3802*4882a593Smuzhiyun *kname = *pr;
3803*4882a593Smuzhiyun if (*pl != *pr) {
3804*4882a593Smuzhiyun key->namlen = klen + 1;
3805*4882a593Smuzhiyun goto free_names;
3806*4882a593Smuzhiyun }
3807*4882a593Smuzhiyun }
3808*4882a593Smuzhiyun
3809*4882a593Smuzhiyun /* l->namlen <= r->namlen since l <= r */
3810*4882a593Smuzhiyun if (lkey.namlen < rkey.namlen) {
3811*4882a593Smuzhiyun *kname = *pr;
3812*4882a593Smuzhiyun key->namlen = klen + 1;
3813*4882a593Smuzhiyun } else /* l->namelen == r->namelen */
3814*4882a593Smuzhiyun key->namlen = klen;
3815*4882a593Smuzhiyun
3816*4882a593Smuzhiyun free_names:
3817*4882a593Smuzhiyun kfree(lkey.name);
3818*4882a593Smuzhiyun kfree(rkey.name);
3819*4882a593Smuzhiyun return 0;
3820*4882a593Smuzhiyun }
3821*4882a593Smuzhiyun
3822*4882a593Smuzhiyun
3823*4882a593Smuzhiyun
3824*4882a593Smuzhiyun /*
3825*4882a593Smuzhiyun * dtGetKey()
3826*4882a593Smuzhiyun *
3827*4882a593Smuzhiyun * function: get key of the entry
3828*4882a593Smuzhiyun */
dtGetKey(dtpage_t * p,int i,struct component_name * key,int flag)3829*4882a593Smuzhiyun static void dtGetKey(dtpage_t * p, int i, /* entry index */
3830*4882a593Smuzhiyun struct component_name * key, int flag)
3831*4882a593Smuzhiyun {
3832*4882a593Smuzhiyun int si;
3833*4882a593Smuzhiyun s8 *stbl;
3834*4882a593Smuzhiyun struct ldtentry *lh;
3835*4882a593Smuzhiyun struct idtentry *ih;
3836*4882a593Smuzhiyun struct dtslot *t;
3837*4882a593Smuzhiyun int namlen, len;
3838*4882a593Smuzhiyun wchar_t *kname;
3839*4882a593Smuzhiyun __le16 *name;
3840*4882a593Smuzhiyun
3841*4882a593Smuzhiyun /* get entry */
3842*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
3843*4882a593Smuzhiyun si = stbl[i];
3844*4882a593Smuzhiyun if (p->header.flag & BT_LEAF) {
3845*4882a593Smuzhiyun lh = (struct ldtentry *) & p->slot[si];
3846*4882a593Smuzhiyun si = lh->next;
3847*4882a593Smuzhiyun namlen = lh->namlen;
3848*4882a593Smuzhiyun name = lh->name;
3849*4882a593Smuzhiyun if (flag & JFS_DIR_INDEX)
3850*4882a593Smuzhiyun len = min(namlen, DTLHDRDATALEN);
3851*4882a593Smuzhiyun else
3852*4882a593Smuzhiyun len = min(namlen, DTLHDRDATALEN_LEGACY);
3853*4882a593Smuzhiyun } else {
3854*4882a593Smuzhiyun ih = (struct idtentry *) & p->slot[si];
3855*4882a593Smuzhiyun si = ih->next;
3856*4882a593Smuzhiyun namlen = ih->namlen;
3857*4882a593Smuzhiyun name = ih->name;
3858*4882a593Smuzhiyun len = min(namlen, DTIHDRDATALEN);
3859*4882a593Smuzhiyun }
3860*4882a593Smuzhiyun
3861*4882a593Smuzhiyun key->namlen = namlen;
3862*4882a593Smuzhiyun kname = key->name;
3863*4882a593Smuzhiyun
3864*4882a593Smuzhiyun /*
3865*4882a593Smuzhiyun * move head/only segment
3866*4882a593Smuzhiyun */
3867*4882a593Smuzhiyun UniStrncpy_from_le(kname, name, len);
3868*4882a593Smuzhiyun
3869*4882a593Smuzhiyun /*
3870*4882a593Smuzhiyun * move additional segment(s)
3871*4882a593Smuzhiyun */
3872*4882a593Smuzhiyun while (si >= 0) {
3873*4882a593Smuzhiyun /* get next segment */
3874*4882a593Smuzhiyun t = &p->slot[si];
3875*4882a593Smuzhiyun kname += len;
3876*4882a593Smuzhiyun namlen -= len;
3877*4882a593Smuzhiyun len = min(namlen, DTSLOTDATALEN);
3878*4882a593Smuzhiyun UniStrncpy_from_le(kname, t->name, len);
3879*4882a593Smuzhiyun
3880*4882a593Smuzhiyun si = t->next;
3881*4882a593Smuzhiyun }
3882*4882a593Smuzhiyun }
3883*4882a593Smuzhiyun
3884*4882a593Smuzhiyun
3885*4882a593Smuzhiyun /*
3886*4882a593Smuzhiyun * dtInsertEntry()
3887*4882a593Smuzhiyun *
3888*4882a593Smuzhiyun * function: allocate free slot(s) and
3889*4882a593Smuzhiyun * write a leaf/internal entry
3890*4882a593Smuzhiyun *
3891*4882a593Smuzhiyun * return: entry slot index
3892*4882a593Smuzhiyun */
dtInsertEntry(dtpage_t * p,int index,struct component_name * key,ddata_t * data,struct dt_lock ** dtlock)3893*4882a593Smuzhiyun static void dtInsertEntry(dtpage_t * p, int index, struct component_name * key,
3894*4882a593Smuzhiyun ddata_t * data, struct dt_lock ** dtlock)
3895*4882a593Smuzhiyun {
3896*4882a593Smuzhiyun struct dtslot *h, *t;
3897*4882a593Smuzhiyun struct ldtentry *lh = NULL;
3898*4882a593Smuzhiyun struct idtentry *ih = NULL;
3899*4882a593Smuzhiyun int hsi, fsi, klen, len, nextindex;
3900*4882a593Smuzhiyun wchar_t *kname;
3901*4882a593Smuzhiyun __le16 *name;
3902*4882a593Smuzhiyun s8 *stbl;
3903*4882a593Smuzhiyun pxd_t *xd;
3904*4882a593Smuzhiyun struct dt_lock *dtlck = *dtlock;
3905*4882a593Smuzhiyun struct lv *lv;
3906*4882a593Smuzhiyun int xsi, n;
3907*4882a593Smuzhiyun s64 bn = 0;
3908*4882a593Smuzhiyun struct metapage *mp = NULL;
3909*4882a593Smuzhiyun
3910*4882a593Smuzhiyun klen = key->namlen;
3911*4882a593Smuzhiyun kname = key->name;
3912*4882a593Smuzhiyun
3913*4882a593Smuzhiyun /* allocate a free slot */
3914*4882a593Smuzhiyun hsi = fsi = p->header.freelist;
3915*4882a593Smuzhiyun h = &p->slot[fsi];
3916*4882a593Smuzhiyun p->header.freelist = h->next;
3917*4882a593Smuzhiyun --p->header.freecnt;
3918*4882a593Smuzhiyun
3919*4882a593Smuzhiyun /* open new linelock */
3920*4882a593Smuzhiyun if (dtlck->index >= dtlck->maxcnt)
3921*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
3922*4882a593Smuzhiyun
3923*4882a593Smuzhiyun lv = & dtlck->lv[dtlck->index];
3924*4882a593Smuzhiyun lv->offset = hsi;
3925*4882a593Smuzhiyun
3926*4882a593Smuzhiyun /* write head/only segment */
3927*4882a593Smuzhiyun if (p->header.flag & BT_LEAF) {
3928*4882a593Smuzhiyun lh = (struct ldtentry *) h;
3929*4882a593Smuzhiyun lh->next = h->next;
3930*4882a593Smuzhiyun lh->inumber = cpu_to_le32(data->leaf.ino);
3931*4882a593Smuzhiyun lh->namlen = klen;
3932*4882a593Smuzhiyun name = lh->name;
3933*4882a593Smuzhiyun if (data->leaf.ip) {
3934*4882a593Smuzhiyun len = min(klen, DTLHDRDATALEN);
3935*4882a593Smuzhiyun if (!(p->header.flag & BT_ROOT))
3936*4882a593Smuzhiyun bn = addressPXD(&p->header.self);
3937*4882a593Smuzhiyun lh->index = cpu_to_le32(add_index(data->leaf.tid,
3938*4882a593Smuzhiyun data->leaf.ip,
3939*4882a593Smuzhiyun bn, index));
3940*4882a593Smuzhiyun } else
3941*4882a593Smuzhiyun len = min(klen, DTLHDRDATALEN_LEGACY);
3942*4882a593Smuzhiyun } else {
3943*4882a593Smuzhiyun ih = (struct idtentry *) h;
3944*4882a593Smuzhiyun ih->next = h->next;
3945*4882a593Smuzhiyun xd = (pxd_t *) ih;
3946*4882a593Smuzhiyun *xd = data->xd;
3947*4882a593Smuzhiyun ih->namlen = klen;
3948*4882a593Smuzhiyun name = ih->name;
3949*4882a593Smuzhiyun len = min(klen, DTIHDRDATALEN);
3950*4882a593Smuzhiyun }
3951*4882a593Smuzhiyun
3952*4882a593Smuzhiyun UniStrncpy_to_le(name, kname, len);
3953*4882a593Smuzhiyun
3954*4882a593Smuzhiyun n = 1;
3955*4882a593Smuzhiyun xsi = hsi;
3956*4882a593Smuzhiyun
3957*4882a593Smuzhiyun /* write additional segment(s) */
3958*4882a593Smuzhiyun t = h;
3959*4882a593Smuzhiyun klen -= len;
3960*4882a593Smuzhiyun while (klen) {
3961*4882a593Smuzhiyun /* get free slot */
3962*4882a593Smuzhiyun fsi = p->header.freelist;
3963*4882a593Smuzhiyun t = &p->slot[fsi];
3964*4882a593Smuzhiyun p->header.freelist = t->next;
3965*4882a593Smuzhiyun --p->header.freecnt;
3966*4882a593Smuzhiyun
3967*4882a593Smuzhiyun /* is next slot contiguous ? */
3968*4882a593Smuzhiyun if (fsi != xsi + 1) {
3969*4882a593Smuzhiyun /* close current linelock */
3970*4882a593Smuzhiyun lv->length = n;
3971*4882a593Smuzhiyun dtlck->index++;
3972*4882a593Smuzhiyun
3973*4882a593Smuzhiyun /* open new linelock */
3974*4882a593Smuzhiyun if (dtlck->index < dtlck->maxcnt)
3975*4882a593Smuzhiyun lv++;
3976*4882a593Smuzhiyun else {
3977*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
3978*4882a593Smuzhiyun lv = & dtlck->lv[0];
3979*4882a593Smuzhiyun }
3980*4882a593Smuzhiyun
3981*4882a593Smuzhiyun lv->offset = fsi;
3982*4882a593Smuzhiyun n = 0;
3983*4882a593Smuzhiyun }
3984*4882a593Smuzhiyun
3985*4882a593Smuzhiyun kname += len;
3986*4882a593Smuzhiyun len = min(klen, DTSLOTDATALEN);
3987*4882a593Smuzhiyun UniStrncpy_to_le(t->name, kname, len);
3988*4882a593Smuzhiyun
3989*4882a593Smuzhiyun n++;
3990*4882a593Smuzhiyun xsi = fsi;
3991*4882a593Smuzhiyun klen -= len;
3992*4882a593Smuzhiyun }
3993*4882a593Smuzhiyun
3994*4882a593Smuzhiyun /* close current linelock */
3995*4882a593Smuzhiyun lv->length = n;
3996*4882a593Smuzhiyun dtlck->index++;
3997*4882a593Smuzhiyun
3998*4882a593Smuzhiyun *dtlock = dtlck;
3999*4882a593Smuzhiyun
4000*4882a593Smuzhiyun /* terminate last/only segment */
4001*4882a593Smuzhiyun if (h == t) {
4002*4882a593Smuzhiyun /* single segment entry */
4003*4882a593Smuzhiyun if (p->header.flag & BT_LEAF)
4004*4882a593Smuzhiyun lh->next = -1;
4005*4882a593Smuzhiyun else
4006*4882a593Smuzhiyun ih->next = -1;
4007*4882a593Smuzhiyun } else
4008*4882a593Smuzhiyun /* multi-segment entry */
4009*4882a593Smuzhiyun t->next = -1;
4010*4882a593Smuzhiyun
4011*4882a593Smuzhiyun /* if insert into middle, shift right succeeding entries in stbl */
4012*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
4013*4882a593Smuzhiyun nextindex = p->header.nextindex;
4014*4882a593Smuzhiyun if (index < nextindex) {
4015*4882a593Smuzhiyun memmove(stbl + index + 1, stbl + index, nextindex - index);
4016*4882a593Smuzhiyun
4017*4882a593Smuzhiyun if ((p->header.flag & BT_LEAF) && data->leaf.ip) {
4018*4882a593Smuzhiyun s64 lblock;
4019*4882a593Smuzhiyun
4020*4882a593Smuzhiyun /*
4021*4882a593Smuzhiyun * Need to update slot number for entries that moved
4022*4882a593Smuzhiyun * in the stbl
4023*4882a593Smuzhiyun */
4024*4882a593Smuzhiyun mp = NULL;
4025*4882a593Smuzhiyun for (n = index + 1; n <= nextindex; n++) {
4026*4882a593Smuzhiyun lh = (struct ldtentry *) & (p->slot[stbl[n]]);
4027*4882a593Smuzhiyun modify_index(data->leaf.tid, data->leaf.ip,
4028*4882a593Smuzhiyun le32_to_cpu(lh->index), bn, n,
4029*4882a593Smuzhiyun &mp, &lblock);
4030*4882a593Smuzhiyun }
4031*4882a593Smuzhiyun if (mp)
4032*4882a593Smuzhiyun release_metapage(mp);
4033*4882a593Smuzhiyun }
4034*4882a593Smuzhiyun }
4035*4882a593Smuzhiyun
4036*4882a593Smuzhiyun stbl[index] = hsi;
4037*4882a593Smuzhiyun
4038*4882a593Smuzhiyun /* advance next available entry index of stbl */
4039*4882a593Smuzhiyun ++p->header.nextindex;
4040*4882a593Smuzhiyun }
4041*4882a593Smuzhiyun
4042*4882a593Smuzhiyun
4043*4882a593Smuzhiyun /*
4044*4882a593Smuzhiyun * dtMoveEntry()
4045*4882a593Smuzhiyun *
4046*4882a593Smuzhiyun * function: move entries from split/left page to new/right page
4047*4882a593Smuzhiyun *
4048*4882a593Smuzhiyun * nextindex of dst page and freelist/freecnt of both pages
4049*4882a593Smuzhiyun * are updated.
4050*4882a593Smuzhiyun */
dtMoveEntry(dtpage_t * sp,int si,dtpage_t * dp,struct dt_lock ** sdtlock,struct dt_lock ** ddtlock,int do_index)4051*4882a593Smuzhiyun static void dtMoveEntry(dtpage_t * sp, int si, dtpage_t * dp,
4052*4882a593Smuzhiyun struct dt_lock ** sdtlock, struct dt_lock ** ddtlock,
4053*4882a593Smuzhiyun int do_index)
4054*4882a593Smuzhiyun {
4055*4882a593Smuzhiyun int ssi, next; /* src slot index */
4056*4882a593Smuzhiyun int di; /* dst entry index */
4057*4882a593Smuzhiyun int dsi; /* dst slot index */
4058*4882a593Smuzhiyun s8 *sstbl, *dstbl; /* sorted entry table */
4059*4882a593Smuzhiyun int snamlen, len;
4060*4882a593Smuzhiyun struct ldtentry *slh, *dlh = NULL;
4061*4882a593Smuzhiyun struct idtentry *sih, *dih = NULL;
4062*4882a593Smuzhiyun struct dtslot *h, *s, *d;
4063*4882a593Smuzhiyun struct dt_lock *sdtlck = *sdtlock, *ddtlck = *ddtlock;
4064*4882a593Smuzhiyun struct lv *slv, *dlv;
4065*4882a593Smuzhiyun int xssi, ns, nd;
4066*4882a593Smuzhiyun int sfsi;
4067*4882a593Smuzhiyun
4068*4882a593Smuzhiyun sstbl = (s8 *) & sp->slot[sp->header.stblindex];
4069*4882a593Smuzhiyun dstbl = (s8 *) & dp->slot[dp->header.stblindex];
4070*4882a593Smuzhiyun
4071*4882a593Smuzhiyun dsi = dp->header.freelist; /* first (whole page) free slot */
4072*4882a593Smuzhiyun sfsi = sp->header.freelist;
4073*4882a593Smuzhiyun
4074*4882a593Smuzhiyun /* linelock destination entry slot */
4075*4882a593Smuzhiyun dlv = & ddtlck->lv[ddtlck->index];
4076*4882a593Smuzhiyun dlv->offset = dsi;
4077*4882a593Smuzhiyun
4078*4882a593Smuzhiyun /* linelock source entry slot */
4079*4882a593Smuzhiyun slv = & sdtlck->lv[sdtlck->index];
4080*4882a593Smuzhiyun slv->offset = sstbl[si];
4081*4882a593Smuzhiyun xssi = slv->offset - 1;
4082*4882a593Smuzhiyun
4083*4882a593Smuzhiyun /*
4084*4882a593Smuzhiyun * move entries
4085*4882a593Smuzhiyun */
4086*4882a593Smuzhiyun ns = nd = 0;
4087*4882a593Smuzhiyun for (di = 0; si < sp->header.nextindex; si++, di++) {
4088*4882a593Smuzhiyun ssi = sstbl[si];
4089*4882a593Smuzhiyun dstbl[di] = dsi;
4090*4882a593Smuzhiyun
4091*4882a593Smuzhiyun /* is next slot contiguous ? */
4092*4882a593Smuzhiyun if (ssi != xssi + 1) {
4093*4882a593Smuzhiyun /* close current linelock */
4094*4882a593Smuzhiyun slv->length = ns;
4095*4882a593Smuzhiyun sdtlck->index++;
4096*4882a593Smuzhiyun
4097*4882a593Smuzhiyun /* open new linelock */
4098*4882a593Smuzhiyun if (sdtlck->index < sdtlck->maxcnt)
4099*4882a593Smuzhiyun slv++;
4100*4882a593Smuzhiyun else {
4101*4882a593Smuzhiyun sdtlck = (struct dt_lock *) txLinelock(sdtlck);
4102*4882a593Smuzhiyun slv = & sdtlck->lv[0];
4103*4882a593Smuzhiyun }
4104*4882a593Smuzhiyun
4105*4882a593Smuzhiyun slv->offset = ssi;
4106*4882a593Smuzhiyun ns = 0;
4107*4882a593Smuzhiyun }
4108*4882a593Smuzhiyun
4109*4882a593Smuzhiyun /*
4110*4882a593Smuzhiyun * move head/only segment of an entry
4111*4882a593Smuzhiyun */
4112*4882a593Smuzhiyun /* get dst slot */
4113*4882a593Smuzhiyun h = d = &dp->slot[dsi];
4114*4882a593Smuzhiyun
4115*4882a593Smuzhiyun /* get src slot and move */
4116*4882a593Smuzhiyun s = &sp->slot[ssi];
4117*4882a593Smuzhiyun if (sp->header.flag & BT_LEAF) {
4118*4882a593Smuzhiyun /* get source entry */
4119*4882a593Smuzhiyun slh = (struct ldtentry *) s;
4120*4882a593Smuzhiyun dlh = (struct ldtentry *) h;
4121*4882a593Smuzhiyun snamlen = slh->namlen;
4122*4882a593Smuzhiyun
4123*4882a593Smuzhiyun if (do_index) {
4124*4882a593Smuzhiyun len = min(snamlen, DTLHDRDATALEN);
4125*4882a593Smuzhiyun dlh->index = slh->index; /* little-endian */
4126*4882a593Smuzhiyun } else
4127*4882a593Smuzhiyun len = min(snamlen, DTLHDRDATALEN_LEGACY);
4128*4882a593Smuzhiyun
4129*4882a593Smuzhiyun memcpy(dlh, slh, 6 + len * 2);
4130*4882a593Smuzhiyun
4131*4882a593Smuzhiyun next = slh->next;
4132*4882a593Smuzhiyun
4133*4882a593Smuzhiyun /* update dst head/only segment next field */
4134*4882a593Smuzhiyun dsi++;
4135*4882a593Smuzhiyun dlh->next = dsi;
4136*4882a593Smuzhiyun } else {
4137*4882a593Smuzhiyun sih = (struct idtentry *) s;
4138*4882a593Smuzhiyun snamlen = sih->namlen;
4139*4882a593Smuzhiyun
4140*4882a593Smuzhiyun len = min(snamlen, DTIHDRDATALEN);
4141*4882a593Smuzhiyun dih = (struct idtentry *) h;
4142*4882a593Smuzhiyun memcpy(dih, sih, 10 + len * 2);
4143*4882a593Smuzhiyun next = sih->next;
4144*4882a593Smuzhiyun
4145*4882a593Smuzhiyun dsi++;
4146*4882a593Smuzhiyun dih->next = dsi;
4147*4882a593Smuzhiyun }
4148*4882a593Smuzhiyun
4149*4882a593Smuzhiyun /* free src head/only segment */
4150*4882a593Smuzhiyun s->next = sfsi;
4151*4882a593Smuzhiyun s->cnt = 1;
4152*4882a593Smuzhiyun sfsi = ssi;
4153*4882a593Smuzhiyun
4154*4882a593Smuzhiyun ns++;
4155*4882a593Smuzhiyun nd++;
4156*4882a593Smuzhiyun xssi = ssi;
4157*4882a593Smuzhiyun
4158*4882a593Smuzhiyun /*
4159*4882a593Smuzhiyun * move additional segment(s) of the entry
4160*4882a593Smuzhiyun */
4161*4882a593Smuzhiyun snamlen -= len;
4162*4882a593Smuzhiyun while ((ssi = next) >= 0) {
4163*4882a593Smuzhiyun /* is next slot contiguous ? */
4164*4882a593Smuzhiyun if (ssi != xssi + 1) {
4165*4882a593Smuzhiyun /* close current linelock */
4166*4882a593Smuzhiyun slv->length = ns;
4167*4882a593Smuzhiyun sdtlck->index++;
4168*4882a593Smuzhiyun
4169*4882a593Smuzhiyun /* open new linelock */
4170*4882a593Smuzhiyun if (sdtlck->index < sdtlck->maxcnt)
4171*4882a593Smuzhiyun slv++;
4172*4882a593Smuzhiyun else {
4173*4882a593Smuzhiyun sdtlck =
4174*4882a593Smuzhiyun (struct dt_lock *)
4175*4882a593Smuzhiyun txLinelock(sdtlck);
4176*4882a593Smuzhiyun slv = & sdtlck->lv[0];
4177*4882a593Smuzhiyun }
4178*4882a593Smuzhiyun
4179*4882a593Smuzhiyun slv->offset = ssi;
4180*4882a593Smuzhiyun ns = 0;
4181*4882a593Smuzhiyun }
4182*4882a593Smuzhiyun
4183*4882a593Smuzhiyun /* get next source segment */
4184*4882a593Smuzhiyun s = &sp->slot[ssi];
4185*4882a593Smuzhiyun
4186*4882a593Smuzhiyun /* get next destination free slot */
4187*4882a593Smuzhiyun d++;
4188*4882a593Smuzhiyun
4189*4882a593Smuzhiyun len = min(snamlen, DTSLOTDATALEN);
4190*4882a593Smuzhiyun UniStrncpy_le(d->name, s->name, len);
4191*4882a593Smuzhiyun
4192*4882a593Smuzhiyun ns++;
4193*4882a593Smuzhiyun nd++;
4194*4882a593Smuzhiyun xssi = ssi;
4195*4882a593Smuzhiyun
4196*4882a593Smuzhiyun dsi++;
4197*4882a593Smuzhiyun d->next = dsi;
4198*4882a593Smuzhiyun
4199*4882a593Smuzhiyun /* free source segment */
4200*4882a593Smuzhiyun next = s->next;
4201*4882a593Smuzhiyun s->next = sfsi;
4202*4882a593Smuzhiyun s->cnt = 1;
4203*4882a593Smuzhiyun sfsi = ssi;
4204*4882a593Smuzhiyun
4205*4882a593Smuzhiyun snamlen -= len;
4206*4882a593Smuzhiyun } /* end while */
4207*4882a593Smuzhiyun
4208*4882a593Smuzhiyun /* terminate dst last/only segment */
4209*4882a593Smuzhiyun if (h == d) {
4210*4882a593Smuzhiyun /* single segment entry */
4211*4882a593Smuzhiyun if (dp->header.flag & BT_LEAF)
4212*4882a593Smuzhiyun dlh->next = -1;
4213*4882a593Smuzhiyun else
4214*4882a593Smuzhiyun dih->next = -1;
4215*4882a593Smuzhiyun } else
4216*4882a593Smuzhiyun /* multi-segment entry */
4217*4882a593Smuzhiyun d->next = -1;
4218*4882a593Smuzhiyun } /* end for */
4219*4882a593Smuzhiyun
4220*4882a593Smuzhiyun /* close current linelock */
4221*4882a593Smuzhiyun slv->length = ns;
4222*4882a593Smuzhiyun sdtlck->index++;
4223*4882a593Smuzhiyun *sdtlock = sdtlck;
4224*4882a593Smuzhiyun
4225*4882a593Smuzhiyun dlv->length = nd;
4226*4882a593Smuzhiyun ddtlck->index++;
4227*4882a593Smuzhiyun *ddtlock = ddtlck;
4228*4882a593Smuzhiyun
4229*4882a593Smuzhiyun /* update source header */
4230*4882a593Smuzhiyun sp->header.freelist = sfsi;
4231*4882a593Smuzhiyun sp->header.freecnt += nd;
4232*4882a593Smuzhiyun
4233*4882a593Smuzhiyun /* update destination header */
4234*4882a593Smuzhiyun dp->header.nextindex = di;
4235*4882a593Smuzhiyun
4236*4882a593Smuzhiyun dp->header.freelist = dsi;
4237*4882a593Smuzhiyun dp->header.freecnt -= nd;
4238*4882a593Smuzhiyun }
4239*4882a593Smuzhiyun
4240*4882a593Smuzhiyun
4241*4882a593Smuzhiyun /*
4242*4882a593Smuzhiyun * dtDeleteEntry()
4243*4882a593Smuzhiyun *
4244*4882a593Smuzhiyun * function: free a (leaf/internal) entry
4245*4882a593Smuzhiyun *
4246*4882a593Smuzhiyun * log freelist header, stbl, and each segment slot of entry
4247*4882a593Smuzhiyun * (even though last/only segment next field is modified,
4248*4882a593Smuzhiyun * physical image logging requires all segment slots of
4249*4882a593Smuzhiyun * the entry logged to avoid applying previous updates
4250*4882a593Smuzhiyun * to the same slots)
4251*4882a593Smuzhiyun */
dtDeleteEntry(dtpage_t * p,int fi,struct dt_lock ** dtlock)4252*4882a593Smuzhiyun static void dtDeleteEntry(dtpage_t * p, int fi, struct dt_lock ** dtlock)
4253*4882a593Smuzhiyun {
4254*4882a593Smuzhiyun int fsi; /* free entry slot index */
4255*4882a593Smuzhiyun s8 *stbl;
4256*4882a593Smuzhiyun struct dtslot *t;
4257*4882a593Smuzhiyun int si, freecnt;
4258*4882a593Smuzhiyun struct dt_lock *dtlck = *dtlock;
4259*4882a593Smuzhiyun struct lv *lv;
4260*4882a593Smuzhiyun int xsi, n;
4261*4882a593Smuzhiyun
4262*4882a593Smuzhiyun /* get free entry slot index */
4263*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
4264*4882a593Smuzhiyun fsi = stbl[fi];
4265*4882a593Smuzhiyun
4266*4882a593Smuzhiyun /* open new linelock */
4267*4882a593Smuzhiyun if (dtlck->index >= dtlck->maxcnt)
4268*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
4269*4882a593Smuzhiyun lv = & dtlck->lv[dtlck->index];
4270*4882a593Smuzhiyun
4271*4882a593Smuzhiyun lv->offset = fsi;
4272*4882a593Smuzhiyun
4273*4882a593Smuzhiyun /* get the head/only segment */
4274*4882a593Smuzhiyun t = &p->slot[fsi];
4275*4882a593Smuzhiyun if (p->header.flag & BT_LEAF)
4276*4882a593Smuzhiyun si = ((struct ldtentry *) t)->next;
4277*4882a593Smuzhiyun else
4278*4882a593Smuzhiyun si = ((struct idtentry *) t)->next;
4279*4882a593Smuzhiyun t->next = si;
4280*4882a593Smuzhiyun t->cnt = 1;
4281*4882a593Smuzhiyun
4282*4882a593Smuzhiyun n = freecnt = 1;
4283*4882a593Smuzhiyun xsi = fsi;
4284*4882a593Smuzhiyun
4285*4882a593Smuzhiyun /* find the last/only segment */
4286*4882a593Smuzhiyun while (si >= 0) {
4287*4882a593Smuzhiyun /* is next slot contiguous ? */
4288*4882a593Smuzhiyun if (si != xsi + 1) {
4289*4882a593Smuzhiyun /* close current linelock */
4290*4882a593Smuzhiyun lv->length = n;
4291*4882a593Smuzhiyun dtlck->index++;
4292*4882a593Smuzhiyun
4293*4882a593Smuzhiyun /* open new linelock */
4294*4882a593Smuzhiyun if (dtlck->index < dtlck->maxcnt)
4295*4882a593Smuzhiyun lv++;
4296*4882a593Smuzhiyun else {
4297*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
4298*4882a593Smuzhiyun lv = & dtlck->lv[0];
4299*4882a593Smuzhiyun }
4300*4882a593Smuzhiyun
4301*4882a593Smuzhiyun lv->offset = si;
4302*4882a593Smuzhiyun n = 0;
4303*4882a593Smuzhiyun }
4304*4882a593Smuzhiyun
4305*4882a593Smuzhiyun n++;
4306*4882a593Smuzhiyun xsi = si;
4307*4882a593Smuzhiyun freecnt++;
4308*4882a593Smuzhiyun
4309*4882a593Smuzhiyun t = &p->slot[si];
4310*4882a593Smuzhiyun t->cnt = 1;
4311*4882a593Smuzhiyun si = t->next;
4312*4882a593Smuzhiyun }
4313*4882a593Smuzhiyun
4314*4882a593Smuzhiyun /* close current linelock */
4315*4882a593Smuzhiyun lv->length = n;
4316*4882a593Smuzhiyun dtlck->index++;
4317*4882a593Smuzhiyun
4318*4882a593Smuzhiyun *dtlock = dtlck;
4319*4882a593Smuzhiyun
4320*4882a593Smuzhiyun /* update freelist */
4321*4882a593Smuzhiyun t->next = p->header.freelist;
4322*4882a593Smuzhiyun p->header.freelist = fsi;
4323*4882a593Smuzhiyun p->header.freecnt += freecnt;
4324*4882a593Smuzhiyun
4325*4882a593Smuzhiyun /* if delete from middle,
4326*4882a593Smuzhiyun * shift left the succedding entries in the stbl
4327*4882a593Smuzhiyun */
4328*4882a593Smuzhiyun si = p->header.nextindex;
4329*4882a593Smuzhiyun if (fi < si - 1)
4330*4882a593Smuzhiyun memmove(&stbl[fi], &stbl[fi + 1], si - fi - 1);
4331*4882a593Smuzhiyun
4332*4882a593Smuzhiyun p->header.nextindex--;
4333*4882a593Smuzhiyun }
4334*4882a593Smuzhiyun
4335*4882a593Smuzhiyun
4336*4882a593Smuzhiyun /*
4337*4882a593Smuzhiyun * dtTruncateEntry()
4338*4882a593Smuzhiyun *
4339*4882a593Smuzhiyun * function: truncate a (leaf/internal) entry
4340*4882a593Smuzhiyun *
4341*4882a593Smuzhiyun * log freelist header, stbl, and each segment slot of entry
4342*4882a593Smuzhiyun * (even though last/only segment next field is modified,
4343*4882a593Smuzhiyun * physical image logging requires all segment slots of
4344*4882a593Smuzhiyun * the entry logged to avoid applying previous updates
4345*4882a593Smuzhiyun * to the same slots)
4346*4882a593Smuzhiyun */
dtTruncateEntry(dtpage_t * p,int ti,struct dt_lock ** dtlock)4347*4882a593Smuzhiyun static void dtTruncateEntry(dtpage_t * p, int ti, struct dt_lock ** dtlock)
4348*4882a593Smuzhiyun {
4349*4882a593Smuzhiyun int tsi; /* truncate entry slot index */
4350*4882a593Smuzhiyun s8 *stbl;
4351*4882a593Smuzhiyun struct dtslot *t;
4352*4882a593Smuzhiyun int si, freecnt;
4353*4882a593Smuzhiyun struct dt_lock *dtlck = *dtlock;
4354*4882a593Smuzhiyun struct lv *lv;
4355*4882a593Smuzhiyun int fsi, xsi, n;
4356*4882a593Smuzhiyun
4357*4882a593Smuzhiyun /* get free entry slot index */
4358*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
4359*4882a593Smuzhiyun tsi = stbl[ti];
4360*4882a593Smuzhiyun
4361*4882a593Smuzhiyun /* open new linelock */
4362*4882a593Smuzhiyun if (dtlck->index >= dtlck->maxcnt)
4363*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
4364*4882a593Smuzhiyun lv = & dtlck->lv[dtlck->index];
4365*4882a593Smuzhiyun
4366*4882a593Smuzhiyun lv->offset = tsi;
4367*4882a593Smuzhiyun
4368*4882a593Smuzhiyun /* get the head/only segment */
4369*4882a593Smuzhiyun t = &p->slot[tsi];
4370*4882a593Smuzhiyun ASSERT(p->header.flag & BT_INTERNAL);
4371*4882a593Smuzhiyun ((struct idtentry *) t)->namlen = 0;
4372*4882a593Smuzhiyun si = ((struct idtentry *) t)->next;
4373*4882a593Smuzhiyun ((struct idtentry *) t)->next = -1;
4374*4882a593Smuzhiyun
4375*4882a593Smuzhiyun n = 1;
4376*4882a593Smuzhiyun freecnt = 0;
4377*4882a593Smuzhiyun fsi = si;
4378*4882a593Smuzhiyun xsi = tsi;
4379*4882a593Smuzhiyun
4380*4882a593Smuzhiyun /* find the last/only segment */
4381*4882a593Smuzhiyun while (si >= 0) {
4382*4882a593Smuzhiyun /* is next slot contiguous ? */
4383*4882a593Smuzhiyun if (si != xsi + 1) {
4384*4882a593Smuzhiyun /* close current linelock */
4385*4882a593Smuzhiyun lv->length = n;
4386*4882a593Smuzhiyun dtlck->index++;
4387*4882a593Smuzhiyun
4388*4882a593Smuzhiyun /* open new linelock */
4389*4882a593Smuzhiyun if (dtlck->index < dtlck->maxcnt)
4390*4882a593Smuzhiyun lv++;
4391*4882a593Smuzhiyun else {
4392*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
4393*4882a593Smuzhiyun lv = & dtlck->lv[0];
4394*4882a593Smuzhiyun }
4395*4882a593Smuzhiyun
4396*4882a593Smuzhiyun lv->offset = si;
4397*4882a593Smuzhiyun n = 0;
4398*4882a593Smuzhiyun }
4399*4882a593Smuzhiyun
4400*4882a593Smuzhiyun n++;
4401*4882a593Smuzhiyun xsi = si;
4402*4882a593Smuzhiyun freecnt++;
4403*4882a593Smuzhiyun
4404*4882a593Smuzhiyun t = &p->slot[si];
4405*4882a593Smuzhiyun t->cnt = 1;
4406*4882a593Smuzhiyun si = t->next;
4407*4882a593Smuzhiyun }
4408*4882a593Smuzhiyun
4409*4882a593Smuzhiyun /* close current linelock */
4410*4882a593Smuzhiyun lv->length = n;
4411*4882a593Smuzhiyun dtlck->index++;
4412*4882a593Smuzhiyun
4413*4882a593Smuzhiyun *dtlock = dtlck;
4414*4882a593Smuzhiyun
4415*4882a593Smuzhiyun /* update freelist */
4416*4882a593Smuzhiyun if (freecnt == 0)
4417*4882a593Smuzhiyun return;
4418*4882a593Smuzhiyun t->next = p->header.freelist;
4419*4882a593Smuzhiyun p->header.freelist = fsi;
4420*4882a593Smuzhiyun p->header.freecnt += freecnt;
4421*4882a593Smuzhiyun }
4422*4882a593Smuzhiyun
4423*4882a593Smuzhiyun
4424*4882a593Smuzhiyun /*
4425*4882a593Smuzhiyun * dtLinelockFreelist()
4426*4882a593Smuzhiyun */
dtLinelockFreelist(dtpage_t * p,int m,struct dt_lock ** dtlock)4427*4882a593Smuzhiyun static void dtLinelockFreelist(dtpage_t * p, /* directory page */
4428*4882a593Smuzhiyun int m, /* max slot index */
4429*4882a593Smuzhiyun struct dt_lock ** dtlock)
4430*4882a593Smuzhiyun {
4431*4882a593Smuzhiyun int fsi; /* free entry slot index */
4432*4882a593Smuzhiyun struct dtslot *t;
4433*4882a593Smuzhiyun int si;
4434*4882a593Smuzhiyun struct dt_lock *dtlck = *dtlock;
4435*4882a593Smuzhiyun struct lv *lv;
4436*4882a593Smuzhiyun int xsi, n;
4437*4882a593Smuzhiyun
4438*4882a593Smuzhiyun /* get free entry slot index */
4439*4882a593Smuzhiyun fsi = p->header.freelist;
4440*4882a593Smuzhiyun
4441*4882a593Smuzhiyun /* open new linelock */
4442*4882a593Smuzhiyun if (dtlck->index >= dtlck->maxcnt)
4443*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
4444*4882a593Smuzhiyun lv = & dtlck->lv[dtlck->index];
4445*4882a593Smuzhiyun
4446*4882a593Smuzhiyun lv->offset = fsi;
4447*4882a593Smuzhiyun
4448*4882a593Smuzhiyun n = 1;
4449*4882a593Smuzhiyun xsi = fsi;
4450*4882a593Smuzhiyun
4451*4882a593Smuzhiyun t = &p->slot[fsi];
4452*4882a593Smuzhiyun si = t->next;
4453*4882a593Smuzhiyun
4454*4882a593Smuzhiyun /* find the last/only segment */
4455*4882a593Smuzhiyun while (si < m && si >= 0) {
4456*4882a593Smuzhiyun /* is next slot contiguous ? */
4457*4882a593Smuzhiyun if (si != xsi + 1) {
4458*4882a593Smuzhiyun /* close current linelock */
4459*4882a593Smuzhiyun lv->length = n;
4460*4882a593Smuzhiyun dtlck->index++;
4461*4882a593Smuzhiyun
4462*4882a593Smuzhiyun /* open new linelock */
4463*4882a593Smuzhiyun if (dtlck->index < dtlck->maxcnt)
4464*4882a593Smuzhiyun lv++;
4465*4882a593Smuzhiyun else {
4466*4882a593Smuzhiyun dtlck = (struct dt_lock *) txLinelock(dtlck);
4467*4882a593Smuzhiyun lv = & dtlck->lv[0];
4468*4882a593Smuzhiyun }
4469*4882a593Smuzhiyun
4470*4882a593Smuzhiyun lv->offset = si;
4471*4882a593Smuzhiyun n = 0;
4472*4882a593Smuzhiyun }
4473*4882a593Smuzhiyun
4474*4882a593Smuzhiyun n++;
4475*4882a593Smuzhiyun xsi = si;
4476*4882a593Smuzhiyun
4477*4882a593Smuzhiyun t = &p->slot[si];
4478*4882a593Smuzhiyun si = t->next;
4479*4882a593Smuzhiyun }
4480*4882a593Smuzhiyun
4481*4882a593Smuzhiyun /* close current linelock */
4482*4882a593Smuzhiyun lv->length = n;
4483*4882a593Smuzhiyun dtlck->index++;
4484*4882a593Smuzhiyun
4485*4882a593Smuzhiyun *dtlock = dtlck;
4486*4882a593Smuzhiyun }
4487*4882a593Smuzhiyun
4488*4882a593Smuzhiyun
4489*4882a593Smuzhiyun /*
4490*4882a593Smuzhiyun * NAME: dtModify
4491*4882a593Smuzhiyun *
4492*4882a593Smuzhiyun * FUNCTION: Modify the inode number part of a directory entry
4493*4882a593Smuzhiyun *
4494*4882a593Smuzhiyun * PARAMETERS:
4495*4882a593Smuzhiyun * tid - Transaction id
4496*4882a593Smuzhiyun * ip - Inode of parent directory
4497*4882a593Smuzhiyun * key - Name of entry to be modified
4498*4882a593Smuzhiyun * orig_ino - Original inode number expected in entry
4499*4882a593Smuzhiyun * new_ino - New inode number to put into entry
4500*4882a593Smuzhiyun * flag - JFS_RENAME
4501*4882a593Smuzhiyun *
4502*4882a593Smuzhiyun * RETURNS:
4503*4882a593Smuzhiyun * -ESTALE - If entry found does not match orig_ino passed in
4504*4882a593Smuzhiyun * -ENOENT - If no entry can be found to match key
4505*4882a593Smuzhiyun * 0 - If successfully modified entry
4506*4882a593Smuzhiyun */
dtModify(tid_t tid,struct inode * ip,struct component_name * key,ino_t * orig_ino,ino_t new_ino,int flag)4507*4882a593Smuzhiyun int dtModify(tid_t tid, struct inode *ip,
4508*4882a593Smuzhiyun struct component_name * key, ino_t * orig_ino, ino_t new_ino, int flag)
4509*4882a593Smuzhiyun {
4510*4882a593Smuzhiyun int rc;
4511*4882a593Smuzhiyun s64 bn;
4512*4882a593Smuzhiyun struct metapage *mp;
4513*4882a593Smuzhiyun dtpage_t *p;
4514*4882a593Smuzhiyun int index;
4515*4882a593Smuzhiyun struct btstack btstack;
4516*4882a593Smuzhiyun struct tlock *tlck;
4517*4882a593Smuzhiyun struct dt_lock *dtlck;
4518*4882a593Smuzhiyun struct lv *lv;
4519*4882a593Smuzhiyun s8 *stbl;
4520*4882a593Smuzhiyun int entry_si; /* entry slot index */
4521*4882a593Smuzhiyun struct ldtentry *entry;
4522*4882a593Smuzhiyun
4523*4882a593Smuzhiyun /*
4524*4882a593Smuzhiyun * search for the entry to modify:
4525*4882a593Smuzhiyun *
4526*4882a593Smuzhiyun * dtSearch() returns (leaf page pinned, index at which to modify).
4527*4882a593Smuzhiyun */
4528*4882a593Smuzhiyun if ((rc = dtSearch(ip, key, orig_ino, &btstack, flag)))
4529*4882a593Smuzhiyun return rc;
4530*4882a593Smuzhiyun
4531*4882a593Smuzhiyun /* retrieve search result */
4532*4882a593Smuzhiyun DT_GETSEARCH(ip, btstack.top, bn, mp, p, index);
4533*4882a593Smuzhiyun
4534*4882a593Smuzhiyun BT_MARK_DIRTY(mp, ip);
4535*4882a593Smuzhiyun /*
4536*4882a593Smuzhiyun * acquire a transaction lock on the leaf page of named entry
4537*4882a593Smuzhiyun */
4538*4882a593Smuzhiyun tlck = txLock(tid, ip, mp, tlckDTREE | tlckENTRY);
4539*4882a593Smuzhiyun dtlck = (struct dt_lock *) & tlck->lock;
4540*4882a593Smuzhiyun
4541*4882a593Smuzhiyun /* get slot index of the entry */
4542*4882a593Smuzhiyun stbl = DT_GETSTBL(p);
4543*4882a593Smuzhiyun entry_si = stbl[index];
4544*4882a593Smuzhiyun
4545*4882a593Smuzhiyun /* linelock entry */
4546*4882a593Smuzhiyun ASSERT(dtlck->index == 0);
4547*4882a593Smuzhiyun lv = & dtlck->lv[0];
4548*4882a593Smuzhiyun lv->offset = entry_si;
4549*4882a593Smuzhiyun lv->length = 1;
4550*4882a593Smuzhiyun dtlck->index++;
4551*4882a593Smuzhiyun
4552*4882a593Smuzhiyun /* get the head/only segment */
4553*4882a593Smuzhiyun entry = (struct ldtentry *) & p->slot[entry_si];
4554*4882a593Smuzhiyun
4555*4882a593Smuzhiyun /* substitute the inode number of the entry */
4556*4882a593Smuzhiyun entry->inumber = cpu_to_le32(new_ino);
4557*4882a593Smuzhiyun
4558*4882a593Smuzhiyun /* unpin the leaf page */
4559*4882a593Smuzhiyun DT_PUTPAGE(mp);
4560*4882a593Smuzhiyun
4561*4882a593Smuzhiyun return 0;
4562*4882a593Smuzhiyun }
4563