btree.c 60 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298
  1. /*
  2. * btree.c - NILFS B-tree.
  3. *
  4. * Copyright (C) 2005-2008 Nippon Telegraph and Telephone Corporation.
  5. *
  6. * This program is free software; you can redistribute it and/or modify
  7. * it under the terms of the GNU General Public License as published by
  8. * the Free Software Foundation; either version 2 of the License, or
  9. * (at your option) any later version.
  10. *
  11. * This program is distributed in the hope that it will be useful,
  12. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  14. * GNU General Public License for more details.
  15. *
  16. * You should have received a copy of the GNU General Public License
  17. * along with this program; if not, write to the Free Software
  18. * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  19. *
  20. * Written by Koji Sato <koji@osrg.net>.
  21. */
  22. #include <linux/slab.h>
  23. #include <linux/string.h>
  24. #include <linux/errno.h>
  25. #include <linux/pagevec.h>
  26. #include "nilfs.h"
  27. #include "page.h"
  28. #include "btnode.h"
  29. #include "btree.h"
  30. #include "alloc.h"
  31. #include "dat.h"
  32. /**
  33. * struct nilfs_btree_path - A path on which B-tree operations are executed
  34. * @bp_bh: buffer head of node block
  35. * @bp_sib_bh: buffer head of sibling node block
  36. * @bp_index: index of child node
  37. * @bp_oldreq: ptr end request for old ptr
  38. * @bp_newreq: ptr alloc request for new ptr
  39. * @bp_op: rebalance operation
  40. */
  41. struct nilfs_btree_path {
  42. struct buffer_head *bp_bh;
  43. struct buffer_head *bp_sib_bh;
  44. int bp_index;
  45. union nilfs_bmap_ptr_req bp_oldreq;
  46. union nilfs_bmap_ptr_req bp_newreq;
  47. struct nilfs_btnode_chkey_ctxt bp_ctxt;
  48. void (*bp_op)(struct nilfs_btree *, struct nilfs_btree_path *,
  49. int, __u64 *, __u64 *);
  50. };
  51. /*
  52. * B-tree path operations
  53. */
  54. static struct kmem_cache *nilfs_btree_path_cache;
  55. int __init nilfs_btree_path_cache_init(void)
  56. {
  57. nilfs_btree_path_cache =
  58. kmem_cache_create("nilfs2_btree_path_cache",
  59. sizeof(struct nilfs_btree_path) *
  60. NILFS_BTREE_LEVEL_MAX, 0, 0, NULL);
  61. return (nilfs_btree_path_cache != NULL) ? 0 : -ENOMEM;
  62. }
  63. void nilfs_btree_path_cache_destroy(void)
  64. {
  65. kmem_cache_destroy(nilfs_btree_path_cache);
  66. }
  67. static inline struct nilfs_btree_path *nilfs_btree_alloc_path(void)
  68. {
  69. return kmem_cache_alloc(nilfs_btree_path_cache, GFP_NOFS);
  70. }
  71. static inline void nilfs_btree_free_path(struct nilfs_btree_path *path)
  72. {
  73. kmem_cache_free(nilfs_btree_path_cache, path);
  74. }
  75. static void nilfs_btree_init_path(struct nilfs_btree_path *path)
  76. {
  77. int level;
  78. for (level = NILFS_BTREE_LEVEL_DATA;
  79. level < NILFS_BTREE_LEVEL_MAX;
  80. level++) {
  81. path[level].bp_bh = NULL;
  82. path[level].bp_sib_bh = NULL;
  83. path[level].bp_index = 0;
  84. path[level].bp_oldreq.bpr_ptr = NILFS_BMAP_INVALID_PTR;
  85. path[level].bp_newreq.bpr_ptr = NILFS_BMAP_INVALID_PTR;
  86. path[level].bp_op = NULL;
  87. }
  88. }
  89. static void nilfs_btree_release_path(struct nilfs_btree_path *path)
  90. {
  91. int level;
  92. for (level = NILFS_BTREE_LEVEL_DATA; level < NILFS_BTREE_LEVEL_MAX;
  93. level++)
  94. brelse(path[level].bp_bh);
  95. }
  96. /*
  97. * B-tree node operations
  98. */
  99. static int nilfs_btree_get_block(const struct nilfs_btree *btree, __u64 ptr,
  100. struct buffer_head **bhp)
  101. {
  102. struct address_space *btnc =
  103. &NILFS_BMAP_I((struct nilfs_bmap *)btree)->i_btnode_cache;
  104. return nilfs_btnode_get(btnc, ptr, 0, bhp, 0);
  105. }
  106. static int nilfs_btree_get_new_block(const struct nilfs_btree *btree,
  107. __u64 ptr, struct buffer_head **bhp)
  108. {
  109. struct address_space *btnc =
  110. &NILFS_BMAP_I((struct nilfs_bmap *)btree)->i_btnode_cache;
  111. int ret;
  112. ret = nilfs_btnode_get(btnc, ptr, 0, bhp, 1);
  113. if (!ret)
  114. set_buffer_nilfs_volatile(*bhp);
  115. return ret;
  116. }
  117. static inline int
  118. nilfs_btree_node_get_flags(const struct nilfs_btree_node *node)
  119. {
  120. return node->bn_flags;
  121. }
  122. static inline void
  123. nilfs_btree_node_set_flags(struct nilfs_btree_node *node, int flags)
  124. {
  125. node->bn_flags = flags;
  126. }
  127. static inline int nilfs_btree_node_root(const struct nilfs_btree_node *node)
  128. {
  129. return nilfs_btree_node_get_flags(node) & NILFS_BTREE_NODE_ROOT;
  130. }
  131. static inline int
  132. nilfs_btree_node_get_level(const struct nilfs_btree_node *node)
  133. {
  134. return node->bn_level;
  135. }
  136. static inline void
  137. nilfs_btree_node_set_level(struct nilfs_btree_node *node, int level)
  138. {
  139. node->bn_level = level;
  140. }
  141. static inline int
  142. nilfs_btree_node_get_nchildren(const struct nilfs_btree_node *node)
  143. {
  144. return le16_to_cpu(node->bn_nchildren);
  145. }
  146. static inline void
  147. nilfs_btree_node_set_nchildren(struct nilfs_btree_node *node, int nchildren)
  148. {
  149. node->bn_nchildren = cpu_to_le16(nchildren);
  150. }
  151. static inline int nilfs_btree_node_size(const struct nilfs_btree *btree)
  152. {
  153. return 1 << btree->bt_bmap.b_inode->i_blkbits;
  154. }
  155. static inline int
  156. nilfs_btree_node_nchildren_min(const struct nilfs_btree_node *node,
  157. const struct nilfs_btree *btree)
  158. {
  159. return nilfs_btree_node_root(node) ?
  160. NILFS_BTREE_ROOT_NCHILDREN_MIN :
  161. NILFS_BTREE_NODE_NCHILDREN_MIN(nilfs_btree_node_size(btree));
  162. }
  163. static inline int
  164. nilfs_btree_node_nchildren_max(const struct nilfs_btree_node *node,
  165. const struct nilfs_btree *btree)
  166. {
  167. return nilfs_btree_node_root(node) ?
  168. NILFS_BTREE_ROOT_NCHILDREN_MAX :
  169. NILFS_BTREE_NODE_NCHILDREN_MAX(nilfs_btree_node_size(btree));
  170. }
  171. static inline __le64 *
  172. nilfs_btree_node_dkeys(const struct nilfs_btree_node *node)
  173. {
  174. return (__le64 *)((char *)(node + 1) +
  175. (nilfs_btree_node_root(node) ?
  176. 0 : NILFS_BTREE_NODE_EXTRA_PAD_SIZE));
  177. }
  178. static inline __le64 *
  179. nilfs_btree_node_dptrs(const struct nilfs_btree_node *node,
  180. const struct nilfs_btree *btree)
  181. {
  182. return (__le64 *)(nilfs_btree_node_dkeys(node) +
  183. nilfs_btree_node_nchildren_max(node, btree));
  184. }
  185. static inline __u64
  186. nilfs_btree_node_get_key(const struct nilfs_btree_node *node, int index)
  187. {
  188. return nilfs_bmap_dkey_to_key(*(nilfs_btree_node_dkeys(node) + index));
  189. }
  190. static inline void
  191. nilfs_btree_node_set_key(struct nilfs_btree_node *node, int index, __u64 key)
  192. {
  193. *(nilfs_btree_node_dkeys(node) + index) = nilfs_bmap_key_to_dkey(key);
  194. }
  195. static inline __u64
  196. nilfs_btree_node_get_ptr(const struct nilfs_btree *btree,
  197. const struct nilfs_btree_node *node, int index)
  198. {
  199. return nilfs_bmap_dptr_to_ptr(*(nilfs_btree_node_dptrs(node, btree) +
  200. index));
  201. }
  202. static inline void
  203. nilfs_btree_node_set_ptr(struct nilfs_btree *btree,
  204. struct nilfs_btree_node *node, int index, __u64 ptr)
  205. {
  206. *(nilfs_btree_node_dptrs(node, btree) + index) =
  207. nilfs_bmap_ptr_to_dptr(ptr);
  208. }
  209. static void nilfs_btree_node_init(struct nilfs_btree *btree,
  210. struct nilfs_btree_node *node,
  211. int flags, int level, int nchildren,
  212. const __u64 *keys, const __u64 *ptrs)
  213. {
  214. __le64 *dkeys;
  215. __le64 *dptrs;
  216. int i;
  217. nilfs_btree_node_set_flags(node, flags);
  218. nilfs_btree_node_set_level(node, level);
  219. nilfs_btree_node_set_nchildren(node, nchildren);
  220. dkeys = nilfs_btree_node_dkeys(node);
  221. dptrs = nilfs_btree_node_dptrs(node, btree);
  222. for (i = 0; i < nchildren; i++) {
  223. dkeys[i] = nilfs_bmap_key_to_dkey(keys[i]);
  224. dptrs[i] = nilfs_bmap_ptr_to_dptr(ptrs[i]);
  225. }
  226. }
  227. /* Assume the buffer heads corresponding to left and right are locked. */
  228. static void nilfs_btree_node_move_left(struct nilfs_btree *btree,
  229. struct nilfs_btree_node *left,
  230. struct nilfs_btree_node *right,
  231. int n)
  232. {
  233. __le64 *ldkeys, *rdkeys;
  234. __le64 *ldptrs, *rdptrs;
  235. int lnchildren, rnchildren;
  236. ldkeys = nilfs_btree_node_dkeys(left);
  237. ldptrs = nilfs_btree_node_dptrs(left, btree);
  238. lnchildren = nilfs_btree_node_get_nchildren(left);
  239. rdkeys = nilfs_btree_node_dkeys(right);
  240. rdptrs = nilfs_btree_node_dptrs(right, btree);
  241. rnchildren = nilfs_btree_node_get_nchildren(right);
  242. memcpy(ldkeys + lnchildren, rdkeys, n * sizeof(*rdkeys));
  243. memcpy(ldptrs + lnchildren, rdptrs, n * sizeof(*rdptrs));
  244. memmove(rdkeys, rdkeys + n, (rnchildren - n) * sizeof(*rdkeys));
  245. memmove(rdptrs, rdptrs + n, (rnchildren - n) * sizeof(*rdptrs));
  246. lnchildren += n;
  247. rnchildren -= n;
  248. nilfs_btree_node_set_nchildren(left, lnchildren);
  249. nilfs_btree_node_set_nchildren(right, rnchildren);
  250. }
  251. /* Assume that the buffer heads corresponding to left and right are locked. */
  252. static void nilfs_btree_node_move_right(struct nilfs_btree *btree,
  253. struct nilfs_btree_node *left,
  254. struct nilfs_btree_node *right,
  255. int n)
  256. {
  257. __le64 *ldkeys, *rdkeys;
  258. __le64 *ldptrs, *rdptrs;
  259. int lnchildren, rnchildren;
  260. ldkeys = nilfs_btree_node_dkeys(left);
  261. ldptrs = nilfs_btree_node_dptrs(left, btree);
  262. lnchildren = nilfs_btree_node_get_nchildren(left);
  263. rdkeys = nilfs_btree_node_dkeys(right);
  264. rdptrs = nilfs_btree_node_dptrs(right, btree);
  265. rnchildren = nilfs_btree_node_get_nchildren(right);
  266. memmove(rdkeys + n, rdkeys, rnchildren * sizeof(*rdkeys));
  267. memmove(rdptrs + n, rdptrs, rnchildren * sizeof(*rdptrs));
  268. memcpy(rdkeys, ldkeys + lnchildren - n, n * sizeof(*rdkeys));
  269. memcpy(rdptrs, ldptrs + lnchildren - n, n * sizeof(*rdptrs));
  270. lnchildren -= n;
  271. rnchildren += n;
  272. nilfs_btree_node_set_nchildren(left, lnchildren);
  273. nilfs_btree_node_set_nchildren(right, rnchildren);
  274. }
  275. /* Assume that the buffer head corresponding to node is locked. */
  276. static void nilfs_btree_node_insert(struct nilfs_btree *btree,
  277. struct nilfs_btree_node *node,
  278. __u64 key, __u64 ptr, int index)
  279. {
  280. __le64 *dkeys;
  281. __le64 *dptrs;
  282. int nchildren;
  283. dkeys = nilfs_btree_node_dkeys(node);
  284. dptrs = nilfs_btree_node_dptrs(node, btree);
  285. nchildren = nilfs_btree_node_get_nchildren(node);
  286. if (index < nchildren) {
  287. memmove(dkeys + index + 1, dkeys + index,
  288. (nchildren - index) * sizeof(*dkeys));
  289. memmove(dptrs + index + 1, dptrs + index,
  290. (nchildren - index) * sizeof(*dptrs));
  291. }
  292. dkeys[index] = nilfs_bmap_key_to_dkey(key);
  293. dptrs[index] = nilfs_bmap_ptr_to_dptr(ptr);
  294. nchildren++;
  295. nilfs_btree_node_set_nchildren(node, nchildren);
  296. }
  297. /* Assume that the buffer head corresponding to node is locked. */
  298. static void nilfs_btree_node_delete(struct nilfs_btree *btree,
  299. struct nilfs_btree_node *node,
  300. __u64 *keyp, __u64 *ptrp, int index)
  301. {
  302. __u64 key;
  303. __u64 ptr;
  304. __le64 *dkeys;
  305. __le64 *dptrs;
  306. int nchildren;
  307. dkeys = nilfs_btree_node_dkeys(node);
  308. dptrs = nilfs_btree_node_dptrs(node, btree);
  309. key = nilfs_bmap_dkey_to_key(dkeys[index]);
  310. ptr = nilfs_bmap_dptr_to_ptr(dptrs[index]);
  311. nchildren = nilfs_btree_node_get_nchildren(node);
  312. if (keyp != NULL)
  313. *keyp = key;
  314. if (ptrp != NULL)
  315. *ptrp = ptr;
  316. if (index < nchildren - 1) {
  317. memmove(dkeys + index, dkeys + index + 1,
  318. (nchildren - index - 1) * sizeof(*dkeys));
  319. memmove(dptrs + index, dptrs + index + 1,
  320. (nchildren - index - 1) * sizeof(*dptrs));
  321. }
  322. nchildren--;
  323. nilfs_btree_node_set_nchildren(node, nchildren);
  324. }
  325. static int nilfs_btree_node_lookup(const struct nilfs_btree_node *node,
  326. __u64 key, int *indexp)
  327. {
  328. __u64 nkey;
  329. int index, low, high, s;
  330. /* binary search */
  331. low = 0;
  332. high = nilfs_btree_node_get_nchildren(node) - 1;
  333. index = 0;
  334. s = 0;
  335. while (low <= high) {
  336. index = (low + high) / 2;
  337. nkey = nilfs_btree_node_get_key(node, index);
  338. if (nkey == key) {
  339. s = 0;
  340. goto out;
  341. } else if (nkey < key) {
  342. low = index + 1;
  343. s = -1;
  344. } else {
  345. high = index - 1;
  346. s = 1;
  347. }
  348. }
  349. /* adjust index */
  350. if (nilfs_btree_node_get_level(node) > NILFS_BTREE_LEVEL_NODE_MIN) {
  351. if (s > 0 && index > 0)
  352. index--;
  353. } else if (s < 0)
  354. index++;
  355. out:
  356. *indexp = index;
  357. return s == 0;
  358. }
  359. static inline struct nilfs_btree_node *
  360. nilfs_btree_get_root(const struct nilfs_btree *btree)
  361. {
  362. return (struct nilfs_btree_node *)btree->bt_bmap.b_u.u_data;
  363. }
  364. static inline struct nilfs_btree_node *
  365. nilfs_btree_get_nonroot_node(const struct nilfs_btree_path *path, int level)
  366. {
  367. return (struct nilfs_btree_node *)path[level].bp_bh->b_data;
  368. }
  369. static inline struct nilfs_btree_node *
  370. nilfs_btree_get_sib_node(const struct nilfs_btree_path *path, int level)
  371. {
  372. return (struct nilfs_btree_node *)path[level].bp_sib_bh->b_data;
  373. }
  374. static inline int nilfs_btree_height(const struct nilfs_btree *btree)
  375. {
  376. return nilfs_btree_node_get_level(nilfs_btree_get_root(btree)) + 1;
  377. }
  378. static inline struct nilfs_btree_node *
  379. nilfs_btree_get_node(const struct nilfs_btree *btree,
  380. const struct nilfs_btree_path *path,
  381. int level)
  382. {
  383. return (level == nilfs_btree_height(btree) - 1) ?
  384. nilfs_btree_get_root(btree) :
  385. nilfs_btree_get_nonroot_node(path, level);
  386. }
  387. static inline int
  388. nilfs_btree_bad_node(struct nilfs_btree_node *node, int level)
  389. {
  390. if (unlikely(nilfs_btree_node_get_level(node) != level)) {
  391. dump_stack();
  392. printk(KERN_CRIT "NILFS: btree level mismatch: %d != %d\n",
  393. nilfs_btree_node_get_level(node), level);
  394. return 1;
  395. }
  396. return 0;
  397. }
  398. static int nilfs_btree_do_lookup(const struct nilfs_btree *btree,
  399. struct nilfs_btree_path *path,
  400. __u64 key, __u64 *ptrp, int minlevel)
  401. {
  402. struct nilfs_btree_node *node;
  403. __u64 ptr;
  404. int level, index, found, ret;
  405. node = nilfs_btree_get_root(btree);
  406. level = nilfs_btree_node_get_level(node);
  407. if (level < minlevel || nilfs_btree_node_get_nchildren(node) <= 0)
  408. return -ENOENT;
  409. found = nilfs_btree_node_lookup(node, key, &index);
  410. ptr = nilfs_btree_node_get_ptr(btree, node, index);
  411. path[level].bp_bh = NULL;
  412. path[level].bp_index = index;
  413. for (level--; level >= minlevel; level--) {
  414. ret = nilfs_btree_get_block(btree, ptr, &path[level].bp_bh);
  415. if (ret < 0)
  416. return ret;
  417. node = nilfs_btree_get_nonroot_node(path, level);
  418. if (nilfs_btree_bad_node(node, level))
  419. return -EINVAL;
  420. if (!found)
  421. found = nilfs_btree_node_lookup(node, key, &index);
  422. else
  423. index = 0;
  424. if (index < nilfs_btree_node_nchildren_max(node, btree))
  425. ptr = nilfs_btree_node_get_ptr(btree, node, index);
  426. else {
  427. WARN_ON(found || level != NILFS_BTREE_LEVEL_NODE_MIN);
  428. /* insert */
  429. ptr = NILFS_BMAP_INVALID_PTR;
  430. }
  431. path[level].bp_index = index;
  432. }
  433. if (!found)
  434. return -ENOENT;
  435. if (ptrp != NULL)
  436. *ptrp = ptr;
  437. return 0;
  438. }
  439. static int nilfs_btree_do_lookup_last(const struct nilfs_btree *btree,
  440. struct nilfs_btree_path *path,
  441. __u64 *keyp, __u64 *ptrp)
  442. {
  443. struct nilfs_btree_node *node;
  444. __u64 ptr;
  445. int index, level, ret;
  446. node = nilfs_btree_get_root(btree);
  447. index = nilfs_btree_node_get_nchildren(node) - 1;
  448. if (index < 0)
  449. return -ENOENT;
  450. level = nilfs_btree_node_get_level(node);
  451. ptr = nilfs_btree_node_get_ptr(btree, node, index);
  452. path[level].bp_bh = NULL;
  453. path[level].bp_index = index;
  454. for (level--; level > 0; level--) {
  455. ret = nilfs_btree_get_block(btree, ptr, &path[level].bp_bh);
  456. if (ret < 0)
  457. return ret;
  458. node = nilfs_btree_get_nonroot_node(path, level);
  459. if (nilfs_btree_bad_node(node, level))
  460. return -EINVAL;
  461. index = nilfs_btree_node_get_nchildren(node) - 1;
  462. ptr = nilfs_btree_node_get_ptr(btree, node, index);
  463. path[level].bp_index = index;
  464. }
  465. if (keyp != NULL)
  466. *keyp = nilfs_btree_node_get_key(node, index);
  467. if (ptrp != NULL)
  468. *ptrp = ptr;
  469. return 0;
  470. }
  471. static int nilfs_btree_lookup(const struct nilfs_bmap *bmap,
  472. __u64 key, int level, __u64 *ptrp)
  473. {
  474. struct nilfs_btree *btree;
  475. struct nilfs_btree_path *path;
  476. __u64 ptr;
  477. int ret;
  478. btree = (struct nilfs_btree *)bmap;
  479. path = nilfs_btree_alloc_path();
  480. if (path == NULL)
  481. return -ENOMEM;
  482. nilfs_btree_init_path(path);
  483. ret = nilfs_btree_do_lookup(btree, path, key, &ptr, level);
  484. if (ptrp != NULL)
  485. *ptrp = ptr;
  486. nilfs_btree_release_path(path);
  487. nilfs_btree_free_path(path);
  488. return ret;
  489. }
  490. static int nilfs_btree_lookup_contig(const struct nilfs_bmap *bmap,
  491. __u64 key, __u64 *ptrp, unsigned maxblocks)
  492. {
  493. struct nilfs_btree *btree = (struct nilfs_btree *)bmap;
  494. struct nilfs_btree_path *path;
  495. struct nilfs_btree_node *node;
  496. struct inode *dat = NULL;
  497. __u64 ptr, ptr2;
  498. sector_t blocknr;
  499. int level = NILFS_BTREE_LEVEL_NODE_MIN;
  500. int ret, cnt, index, maxlevel;
  501. path = nilfs_btree_alloc_path();
  502. if (path == NULL)
  503. return -ENOMEM;
  504. nilfs_btree_init_path(path);
  505. ret = nilfs_btree_do_lookup(btree, path, key, &ptr, level);
  506. if (ret < 0)
  507. goto out;
  508. if (NILFS_BMAP_USE_VBN(bmap)) {
  509. dat = nilfs_bmap_get_dat(bmap);
  510. ret = nilfs_dat_translate(dat, ptr, &blocknr);
  511. if (ret < 0)
  512. goto out;
  513. ptr = blocknr;
  514. }
  515. cnt = 1;
  516. if (cnt == maxblocks)
  517. goto end;
  518. maxlevel = nilfs_btree_height(btree) - 1;
  519. node = nilfs_btree_get_node(btree, path, level);
  520. index = path[level].bp_index + 1;
  521. for (;;) {
  522. while (index < nilfs_btree_node_get_nchildren(node)) {
  523. if (nilfs_btree_node_get_key(node, index) !=
  524. key + cnt)
  525. goto end;
  526. ptr2 = nilfs_btree_node_get_ptr(btree, node, index);
  527. if (dat) {
  528. ret = nilfs_dat_translate(dat, ptr2, &blocknr);
  529. if (ret < 0)
  530. goto out;
  531. ptr2 = blocknr;
  532. }
  533. if (ptr2 != ptr + cnt || ++cnt == maxblocks)
  534. goto end;
  535. index++;
  536. continue;
  537. }
  538. if (level == maxlevel)
  539. break;
  540. /* look-up right sibling node */
  541. node = nilfs_btree_get_node(btree, path, level + 1);
  542. index = path[level + 1].bp_index + 1;
  543. if (index >= nilfs_btree_node_get_nchildren(node) ||
  544. nilfs_btree_node_get_key(node, index) != key + cnt)
  545. break;
  546. ptr2 = nilfs_btree_node_get_ptr(btree, node, index);
  547. path[level + 1].bp_index = index;
  548. brelse(path[level].bp_bh);
  549. path[level].bp_bh = NULL;
  550. ret = nilfs_btree_get_block(btree, ptr2, &path[level].bp_bh);
  551. if (ret < 0)
  552. goto out;
  553. node = nilfs_btree_get_nonroot_node(path, level);
  554. index = 0;
  555. path[level].bp_index = index;
  556. }
  557. end:
  558. *ptrp = ptr;
  559. ret = cnt;
  560. out:
  561. nilfs_btree_release_path(path);
  562. nilfs_btree_free_path(path);
  563. return ret;
  564. }
  565. static void nilfs_btree_promote_key(struct nilfs_btree *btree,
  566. struct nilfs_btree_path *path,
  567. int level, __u64 key)
  568. {
  569. if (level < nilfs_btree_height(btree) - 1) {
  570. do {
  571. lock_buffer(path[level].bp_bh);
  572. nilfs_btree_node_set_key(
  573. nilfs_btree_get_nonroot_node(path, level),
  574. path[level].bp_index, key);
  575. if (!buffer_dirty(path[level].bp_bh))
  576. nilfs_btnode_mark_dirty(path[level].bp_bh);
  577. unlock_buffer(path[level].bp_bh);
  578. } while ((path[level].bp_index == 0) &&
  579. (++level < nilfs_btree_height(btree) - 1));
  580. }
  581. /* root */
  582. if (level == nilfs_btree_height(btree) - 1) {
  583. nilfs_btree_node_set_key(nilfs_btree_get_root(btree),
  584. path[level].bp_index, key);
  585. }
  586. }
  587. static void nilfs_btree_do_insert(struct nilfs_btree *btree,
  588. struct nilfs_btree_path *path,
  589. int level, __u64 *keyp, __u64 *ptrp)
  590. {
  591. struct nilfs_btree_node *node;
  592. if (level < nilfs_btree_height(btree) - 1) {
  593. lock_buffer(path[level].bp_bh);
  594. node = nilfs_btree_get_nonroot_node(path, level);
  595. nilfs_btree_node_insert(btree, node, *keyp, *ptrp,
  596. path[level].bp_index);
  597. if (!buffer_dirty(path[level].bp_bh))
  598. nilfs_btnode_mark_dirty(path[level].bp_bh);
  599. unlock_buffer(path[level].bp_bh);
  600. if (path[level].bp_index == 0)
  601. nilfs_btree_promote_key(btree, path, level + 1,
  602. nilfs_btree_node_get_key(node,
  603. 0));
  604. } else {
  605. node = nilfs_btree_get_root(btree);
  606. nilfs_btree_node_insert(btree, node, *keyp, *ptrp,
  607. path[level].bp_index);
  608. }
  609. }
  610. static void nilfs_btree_carry_left(struct nilfs_btree *btree,
  611. struct nilfs_btree_path *path,
  612. int level, __u64 *keyp, __u64 *ptrp)
  613. {
  614. struct nilfs_btree_node *node, *left;
  615. int nchildren, lnchildren, n, move;
  616. lock_buffer(path[level].bp_bh);
  617. lock_buffer(path[level].bp_sib_bh);
  618. node = nilfs_btree_get_nonroot_node(path, level);
  619. left = nilfs_btree_get_sib_node(path, level);
  620. nchildren = nilfs_btree_node_get_nchildren(node);
  621. lnchildren = nilfs_btree_node_get_nchildren(left);
  622. move = 0;
  623. n = (nchildren + lnchildren + 1) / 2 - lnchildren;
  624. if (n > path[level].bp_index) {
  625. /* move insert point */
  626. n--;
  627. move = 1;
  628. }
  629. nilfs_btree_node_move_left(btree, left, node, n);
  630. if (!buffer_dirty(path[level].bp_bh))
  631. nilfs_btnode_mark_dirty(path[level].bp_bh);
  632. if (!buffer_dirty(path[level].bp_sib_bh))
  633. nilfs_btnode_mark_dirty(path[level].bp_sib_bh);
  634. unlock_buffer(path[level].bp_bh);
  635. unlock_buffer(path[level].bp_sib_bh);
  636. nilfs_btree_promote_key(btree, path, level + 1,
  637. nilfs_btree_node_get_key(node, 0));
  638. if (move) {
  639. brelse(path[level].bp_bh);
  640. path[level].bp_bh = path[level].bp_sib_bh;
  641. path[level].bp_sib_bh = NULL;
  642. path[level].bp_index += lnchildren;
  643. path[level + 1].bp_index--;
  644. } else {
  645. brelse(path[level].bp_sib_bh);
  646. path[level].bp_sib_bh = NULL;
  647. path[level].bp_index -= n;
  648. }
  649. nilfs_btree_do_insert(btree, path, level, keyp, ptrp);
  650. }
  651. static void nilfs_btree_carry_right(struct nilfs_btree *btree,
  652. struct nilfs_btree_path *path,
  653. int level, __u64 *keyp, __u64 *ptrp)
  654. {
  655. struct nilfs_btree_node *node, *right;
  656. int nchildren, rnchildren, n, move;
  657. lock_buffer(path[level].bp_bh);
  658. lock_buffer(path[level].bp_sib_bh);
  659. node = nilfs_btree_get_nonroot_node(path, level);
  660. right = nilfs_btree_get_sib_node(path, level);
  661. nchildren = nilfs_btree_node_get_nchildren(node);
  662. rnchildren = nilfs_btree_node_get_nchildren(right);
  663. move = 0;
  664. n = (nchildren + rnchildren + 1) / 2 - rnchildren;
  665. if (n > nchildren - path[level].bp_index) {
  666. /* move insert point */
  667. n--;
  668. move = 1;
  669. }
  670. nilfs_btree_node_move_right(btree, node, right, n);
  671. if (!buffer_dirty(path[level].bp_bh))
  672. nilfs_btnode_mark_dirty(path[level].bp_bh);
  673. if (!buffer_dirty(path[level].bp_sib_bh))
  674. nilfs_btnode_mark_dirty(path[level].bp_sib_bh);
  675. unlock_buffer(path[level].bp_bh);
  676. unlock_buffer(path[level].bp_sib_bh);
  677. path[level + 1].bp_index++;
  678. nilfs_btree_promote_key(btree, path, level + 1,
  679. nilfs_btree_node_get_key(right, 0));
  680. path[level + 1].bp_index--;
  681. if (move) {
  682. brelse(path[level].bp_bh);
  683. path[level].bp_bh = path[level].bp_sib_bh;
  684. path[level].bp_sib_bh = NULL;
  685. path[level].bp_index -= nilfs_btree_node_get_nchildren(node);
  686. path[level + 1].bp_index++;
  687. } else {
  688. brelse(path[level].bp_sib_bh);
  689. path[level].bp_sib_bh = NULL;
  690. }
  691. nilfs_btree_do_insert(btree, path, level, keyp, ptrp);
  692. }
  693. static void nilfs_btree_split(struct nilfs_btree *btree,
  694. struct nilfs_btree_path *path,
  695. int level, __u64 *keyp, __u64 *ptrp)
  696. {
  697. struct nilfs_btree_node *node, *right;
  698. __u64 newkey;
  699. __u64 newptr;
  700. int nchildren, n, move;
  701. lock_buffer(path[level].bp_bh);
  702. lock_buffer(path[level].bp_sib_bh);
  703. node = nilfs_btree_get_nonroot_node(path, level);
  704. right = nilfs_btree_get_sib_node(path, level);
  705. nchildren = nilfs_btree_node_get_nchildren(node);
  706. move = 0;
  707. n = (nchildren + 1) / 2;
  708. if (n > nchildren - path[level].bp_index) {
  709. n--;
  710. move = 1;
  711. }
  712. nilfs_btree_node_move_right(btree, node, right, n);
  713. if (!buffer_dirty(path[level].bp_bh))
  714. nilfs_btnode_mark_dirty(path[level].bp_bh);
  715. if (!buffer_dirty(path[level].bp_sib_bh))
  716. nilfs_btnode_mark_dirty(path[level].bp_sib_bh);
  717. unlock_buffer(path[level].bp_bh);
  718. unlock_buffer(path[level].bp_sib_bh);
  719. newkey = nilfs_btree_node_get_key(right, 0);
  720. newptr = path[level].bp_newreq.bpr_ptr;
  721. if (move) {
  722. path[level].bp_index -= nilfs_btree_node_get_nchildren(node);
  723. nilfs_btree_node_insert(btree, right, *keyp, *ptrp,
  724. path[level].bp_index);
  725. *keyp = nilfs_btree_node_get_key(right, 0);
  726. *ptrp = path[level].bp_newreq.bpr_ptr;
  727. brelse(path[level].bp_bh);
  728. path[level].bp_bh = path[level].bp_sib_bh;
  729. path[level].bp_sib_bh = NULL;
  730. } else {
  731. nilfs_btree_do_insert(btree, path, level, keyp, ptrp);
  732. *keyp = nilfs_btree_node_get_key(right, 0);
  733. *ptrp = path[level].bp_newreq.bpr_ptr;
  734. brelse(path[level].bp_sib_bh);
  735. path[level].bp_sib_bh = NULL;
  736. }
  737. path[level + 1].bp_index++;
  738. }
  739. static void nilfs_btree_grow(struct nilfs_btree *btree,
  740. struct nilfs_btree_path *path,
  741. int level, __u64 *keyp, __u64 *ptrp)
  742. {
  743. struct nilfs_btree_node *root, *child;
  744. int n;
  745. lock_buffer(path[level].bp_sib_bh);
  746. root = nilfs_btree_get_root(btree);
  747. child = nilfs_btree_get_sib_node(path, level);
  748. n = nilfs_btree_node_get_nchildren(root);
  749. nilfs_btree_node_move_right(btree, root, child, n);
  750. nilfs_btree_node_set_level(root, level + 1);
  751. if (!buffer_dirty(path[level].bp_sib_bh))
  752. nilfs_btnode_mark_dirty(path[level].bp_sib_bh);
  753. unlock_buffer(path[level].bp_sib_bh);
  754. path[level].bp_bh = path[level].bp_sib_bh;
  755. path[level].bp_sib_bh = NULL;
  756. nilfs_btree_do_insert(btree, path, level, keyp, ptrp);
  757. *keyp = nilfs_btree_node_get_key(child, 0);
  758. *ptrp = path[level].bp_newreq.bpr_ptr;
  759. }
  760. static __u64 nilfs_btree_find_near(const struct nilfs_btree *btree,
  761. const struct nilfs_btree_path *path)
  762. {
  763. struct nilfs_btree_node *node;
  764. int level;
  765. if (path == NULL)
  766. return NILFS_BMAP_INVALID_PTR;
  767. /* left sibling */
  768. level = NILFS_BTREE_LEVEL_NODE_MIN;
  769. if (path[level].bp_index > 0) {
  770. node = nilfs_btree_get_node(btree, path, level);
  771. return nilfs_btree_node_get_ptr(btree, node,
  772. path[level].bp_index - 1);
  773. }
  774. /* parent */
  775. level = NILFS_BTREE_LEVEL_NODE_MIN + 1;
  776. if (level <= nilfs_btree_height(btree) - 1) {
  777. node = nilfs_btree_get_node(btree, path, level);
  778. return nilfs_btree_node_get_ptr(btree, node,
  779. path[level].bp_index);
  780. }
  781. return NILFS_BMAP_INVALID_PTR;
  782. }
  783. static __u64 nilfs_btree_find_target_v(const struct nilfs_btree *btree,
  784. const struct nilfs_btree_path *path,
  785. __u64 key)
  786. {
  787. __u64 ptr;
  788. ptr = nilfs_bmap_find_target_seq(&btree->bt_bmap, key);
  789. if (ptr != NILFS_BMAP_INVALID_PTR)
  790. /* sequential access */
  791. return ptr;
  792. else {
  793. ptr = nilfs_btree_find_near(btree, path);
  794. if (ptr != NILFS_BMAP_INVALID_PTR)
  795. /* near */
  796. return ptr;
  797. }
  798. /* block group */
  799. return nilfs_bmap_find_target_in_group(&btree->bt_bmap);
  800. }
  801. static void nilfs_btree_set_target_v(struct nilfs_btree *btree, __u64 key,
  802. __u64 ptr)
  803. {
  804. btree->bt_bmap.b_last_allocated_key = key;
  805. btree->bt_bmap.b_last_allocated_ptr = ptr;
  806. }
  807. static int nilfs_btree_prepare_insert(struct nilfs_btree *btree,
  808. struct nilfs_btree_path *path,
  809. int *levelp, __u64 key, __u64 ptr,
  810. struct nilfs_bmap_stats *stats)
  811. {
  812. struct buffer_head *bh;
  813. struct nilfs_btree_node *node, *parent, *sib;
  814. __u64 sibptr;
  815. int pindex, level, ret;
  816. struct inode *dat = NULL;
  817. stats->bs_nblocks = 0;
  818. level = NILFS_BTREE_LEVEL_DATA;
  819. /* allocate a new ptr for data block */
  820. if (NILFS_BMAP_USE_VBN(&btree->bt_bmap)) {
  821. path[level].bp_newreq.bpr_ptr =
  822. nilfs_btree_find_target_v(btree, path, key);
  823. dat = nilfs_bmap_get_dat(&btree->bt_bmap);
  824. }
  825. ret = nilfs_bmap_prepare_alloc_ptr(&btree->bt_bmap,
  826. &path[level].bp_newreq, dat);
  827. if (ret < 0)
  828. goto err_out_data;
  829. for (level = NILFS_BTREE_LEVEL_NODE_MIN;
  830. level < nilfs_btree_height(btree) - 1;
  831. level++) {
  832. node = nilfs_btree_get_nonroot_node(path, level);
  833. if (nilfs_btree_node_get_nchildren(node) <
  834. nilfs_btree_node_nchildren_max(node, btree)) {
  835. path[level].bp_op = nilfs_btree_do_insert;
  836. stats->bs_nblocks++;
  837. goto out;
  838. }
  839. parent = nilfs_btree_get_node(btree, path, level + 1);
  840. pindex = path[level + 1].bp_index;
  841. /* left sibling */
  842. if (pindex > 0) {
  843. sibptr = nilfs_btree_node_get_ptr(btree, parent,
  844. pindex - 1);
  845. ret = nilfs_btree_get_block(btree, sibptr, &bh);
  846. if (ret < 0)
  847. goto err_out_child_node;
  848. sib = (struct nilfs_btree_node *)bh->b_data;
  849. if (nilfs_btree_node_get_nchildren(sib) <
  850. nilfs_btree_node_nchildren_max(sib, btree)) {
  851. path[level].bp_sib_bh = bh;
  852. path[level].bp_op = nilfs_btree_carry_left;
  853. stats->bs_nblocks++;
  854. goto out;
  855. } else
  856. brelse(bh);
  857. }
  858. /* right sibling */
  859. if (pindex <
  860. nilfs_btree_node_get_nchildren(parent) - 1) {
  861. sibptr = nilfs_btree_node_get_ptr(btree, parent,
  862. pindex + 1);
  863. ret = nilfs_btree_get_block(btree, sibptr, &bh);
  864. if (ret < 0)
  865. goto err_out_child_node;
  866. sib = (struct nilfs_btree_node *)bh->b_data;
  867. if (nilfs_btree_node_get_nchildren(sib) <
  868. nilfs_btree_node_nchildren_max(sib, btree)) {
  869. path[level].bp_sib_bh = bh;
  870. path[level].bp_op = nilfs_btree_carry_right;
  871. stats->bs_nblocks++;
  872. goto out;
  873. } else
  874. brelse(bh);
  875. }
  876. /* split */
  877. path[level].bp_newreq.bpr_ptr =
  878. path[level - 1].bp_newreq.bpr_ptr + 1;
  879. ret = nilfs_bmap_prepare_alloc_ptr(&btree->bt_bmap,
  880. &path[level].bp_newreq, dat);
  881. if (ret < 0)
  882. goto err_out_child_node;
  883. ret = nilfs_btree_get_new_block(btree,
  884. path[level].bp_newreq.bpr_ptr,
  885. &bh);
  886. if (ret < 0)
  887. goto err_out_curr_node;
  888. stats->bs_nblocks++;
  889. lock_buffer(bh);
  890. nilfs_btree_node_init(btree,
  891. (struct nilfs_btree_node *)bh->b_data,
  892. 0, level, 0, NULL, NULL);
  893. unlock_buffer(bh);
  894. path[level].bp_sib_bh = bh;
  895. path[level].bp_op = nilfs_btree_split;
  896. }
  897. /* root */
  898. node = nilfs_btree_get_root(btree);
  899. if (nilfs_btree_node_get_nchildren(node) <
  900. nilfs_btree_node_nchildren_max(node, btree)) {
  901. path[level].bp_op = nilfs_btree_do_insert;
  902. stats->bs_nblocks++;
  903. goto out;
  904. }
  905. /* grow */
  906. path[level].bp_newreq.bpr_ptr = path[level - 1].bp_newreq.bpr_ptr + 1;
  907. ret = nilfs_bmap_prepare_alloc_ptr(&btree->bt_bmap,
  908. &path[level].bp_newreq, dat);
  909. if (ret < 0)
  910. goto err_out_child_node;
  911. ret = nilfs_btree_get_new_block(btree, path[level].bp_newreq.bpr_ptr,
  912. &bh);
  913. if (ret < 0)
  914. goto err_out_curr_node;
  915. lock_buffer(bh);
  916. nilfs_btree_node_init(btree, (struct nilfs_btree_node *)bh->b_data,
  917. 0, level, 0, NULL, NULL);
  918. unlock_buffer(bh);
  919. path[level].bp_sib_bh = bh;
  920. path[level].bp_op = nilfs_btree_grow;
  921. level++;
  922. path[level].bp_op = nilfs_btree_do_insert;
  923. /* a newly-created node block and a data block are added */
  924. stats->bs_nblocks += 2;
  925. /* success */
  926. out:
  927. *levelp = level;
  928. return ret;
  929. /* error */
  930. err_out_curr_node:
  931. nilfs_bmap_abort_alloc_ptr(&btree->bt_bmap, &path[level].bp_newreq,
  932. dat);
  933. err_out_child_node:
  934. for (level--; level > NILFS_BTREE_LEVEL_DATA; level--) {
  935. nilfs_btnode_delete(path[level].bp_sib_bh);
  936. nilfs_bmap_abort_alloc_ptr(&btree->bt_bmap,
  937. &path[level].bp_newreq, dat);
  938. }
  939. nilfs_bmap_abort_alloc_ptr(&btree->bt_bmap, &path[level].bp_newreq,
  940. dat);
  941. err_out_data:
  942. *levelp = level;
  943. stats->bs_nblocks = 0;
  944. return ret;
  945. }
  946. static void nilfs_btree_commit_insert(struct nilfs_btree *btree,
  947. struct nilfs_btree_path *path,
  948. int maxlevel, __u64 key, __u64 ptr)
  949. {
  950. struct inode *dat = NULL;
  951. int level;
  952. set_buffer_nilfs_volatile((struct buffer_head *)((unsigned long)ptr));
  953. ptr = path[NILFS_BTREE_LEVEL_DATA].bp_newreq.bpr_ptr;
  954. if (NILFS_BMAP_USE_VBN(&btree->bt_bmap)) {
  955. nilfs_btree_set_target_v(btree, key, ptr);
  956. dat = nilfs_bmap_get_dat(&btree->bt_bmap);
  957. }
  958. for (level = NILFS_BTREE_LEVEL_NODE_MIN; level <= maxlevel; level++) {
  959. nilfs_bmap_commit_alloc_ptr(&btree->bt_bmap,
  960. &path[level - 1].bp_newreq, dat);
  961. path[level].bp_op(btree, path, level, &key, &ptr);
  962. }
  963. if (!nilfs_bmap_dirty(&btree->bt_bmap))
  964. nilfs_bmap_set_dirty(&btree->bt_bmap);
  965. }
  966. static int nilfs_btree_insert(struct nilfs_bmap *bmap, __u64 key, __u64 ptr)
  967. {
  968. struct nilfs_btree *btree;
  969. struct nilfs_btree_path *path;
  970. struct nilfs_bmap_stats stats;
  971. int level, ret;
  972. btree = (struct nilfs_btree *)bmap;
  973. path = nilfs_btree_alloc_path();
  974. if (path == NULL)
  975. return -ENOMEM;
  976. nilfs_btree_init_path(path);
  977. ret = nilfs_btree_do_lookup(btree, path, key, NULL,
  978. NILFS_BTREE_LEVEL_NODE_MIN);
  979. if (ret != -ENOENT) {
  980. if (ret == 0)
  981. ret = -EEXIST;
  982. goto out;
  983. }
  984. ret = nilfs_btree_prepare_insert(btree, path, &level, key, ptr, &stats);
  985. if (ret < 0)
  986. goto out;
  987. nilfs_btree_commit_insert(btree, path, level, key, ptr);
  988. nilfs_bmap_add_blocks(bmap, stats.bs_nblocks);
  989. out:
  990. nilfs_btree_release_path(path);
  991. nilfs_btree_free_path(path);
  992. return ret;
  993. }
  994. static void nilfs_btree_do_delete(struct nilfs_btree *btree,
  995. struct nilfs_btree_path *path,
  996. int level, __u64 *keyp, __u64 *ptrp)
  997. {
  998. struct nilfs_btree_node *node;
  999. if (level < nilfs_btree_height(btree) - 1) {
  1000. lock_buffer(path[level].bp_bh);
  1001. node = nilfs_btree_get_nonroot_node(path, level);
  1002. nilfs_btree_node_delete(btree, node, keyp, ptrp,
  1003. path[level].bp_index);
  1004. if (!buffer_dirty(path[level].bp_bh))
  1005. nilfs_btnode_mark_dirty(path[level].bp_bh);
  1006. unlock_buffer(path[level].bp_bh);
  1007. if (path[level].bp_index == 0)
  1008. nilfs_btree_promote_key(btree, path, level + 1,
  1009. nilfs_btree_node_get_key(node, 0));
  1010. } else {
  1011. node = nilfs_btree_get_root(btree);
  1012. nilfs_btree_node_delete(btree, node, keyp, ptrp,
  1013. path[level].bp_index);
  1014. }
  1015. }
  1016. static void nilfs_btree_borrow_left(struct nilfs_btree *btree,
  1017. struct nilfs_btree_path *path,
  1018. int level, __u64 *keyp, __u64 *ptrp)
  1019. {
  1020. struct nilfs_btree_node *node, *left;
  1021. int nchildren, lnchildren, n;
  1022. nilfs_btree_do_delete(btree, path, level, keyp, ptrp);
  1023. lock_buffer(path[level].bp_bh);
  1024. lock_buffer(path[level].bp_sib_bh);
  1025. node = nilfs_btree_get_nonroot_node(path, level);
  1026. left = nilfs_btree_get_sib_node(path, level);
  1027. nchildren = nilfs_btree_node_get_nchildren(node);
  1028. lnchildren = nilfs_btree_node_get_nchildren(left);
  1029. n = (nchildren + lnchildren) / 2 - nchildren;
  1030. nilfs_btree_node_move_right(btree, left, node, n);
  1031. if (!buffer_dirty(path[level].bp_bh))
  1032. nilfs_btnode_mark_dirty(path[level].bp_bh);
  1033. if (!buffer_dirty(path[level].bp_sib_bh))
  1034. nilfs_btnode_mark_dirty(path[level].bp_sib_bh);
  1035. unlock_buffer(path[level].bp_bh);
  1036. unlock_buffer(path[level].bp_sib_bh);
  1037. nilfs_btree_promote_key(btree, path, level + 1,
  1038. nilfs_btree_node_get_key(node, 0));
  1039. brelse(path[level].bp_sib_bh);
  1040. path[level].bp_sib_bh = NULL;
  1041. path[level].bp_index += n;
  1042. }
  1043. static void nilfs_btree_borrow_right(struct nilfs_btree *btree,
  1044. struct nilfs_btree_path *path,
  1045. int level, __u64 *keyp, __u64 *ptrp)
  1046. {
  1047. struct nilfs_btree_node *node, *right;
  1048. int nchildren, rnchildren, n;
  1049. nilfs_btree_do_delete(btree, path, level, keyp, ptrp);
  1050. lock_buffer(path[level].bp_bh);
  1051. lock_buffer(path[level].bp_sib_bh);
  1052. node = nilfs_btree_get_nonroot_node(path, level);
  1053. right = nilfs_btree_get_sib_node(path, level);
  1054. nchildren = nilfs_btree_node_get_nchildren(node);
  1055. rnchildren = nilfs_btree_node_get_nchildren(right);
  1056. n = (nchildren + rnchildren) / 2 - nchildren;
  1057. nilfs_btree_node_move_left(btree, node, right, n);
  1058. if (!buffer_dirty(path[level].bp_bh))
  1059. nilfs_btnode_mark_dirty(path[level].bp_bh);
  1060. if (!buffer_dirty(path[level].bp_sib_bh))
  1061. nilfs_btnode_mark_dirty(path[level].bp_sib_bh);
  1062. unlock_buffer(path[level].bp_bh);
  1063. unlock_buffer(path[level].bp_sib_bh);
  1064. path[level + 1].bp_index++;
  1065. nilfs_btree_promote_key(btree, path, level + 1,
  1066. nilfs_btree_node_get_key(right, 0));
  1067. path[level + 1].bp_index--;
  1068. brelse(path[level].bp_sib_bh);
  1069. path[level].bp_sib_bh = NULL;
  1070. }
  1071. static void nilfs_btree_concat_left(struct nilfs_btree *btree,
  1072. struct nilfs_btree_path *path,
  1073. int level, __u64 *keyp, __u64 *ptrp)
  1074. {
  1075. struct nilfs_btree_node *node, *left;
  1076. int n;
  1077. nilfs_btree_do_delete(btree, path, level, keyp, ptrp);
  1078. lock_buffer(path[level].bp_bh);
  1079. lock_buffer(path[level].bp_sib_bh);
  1080. node = nilfs_btree_get_nonroot_node(path, level);
  1081. left = nilfs_btree_get_sib_node(path, level);
  1082. n = nilfs_btree_node_get_nchildren(node);
  1083. nilfs_btree_node_move_left(btree, left, node, n);
  1084. if (!buffer_dirty(path[level].bp_sib_bh))
  1085. nilfs_btnode_mark_dirty(path[level].bp_sib_bh);
  1086. unlock_buffer(path[level].bp_bh);
  1087. unlock_buffer(path[level].bp_sib_bh);
  1088. nilfs_btnode_delete(path[level].bp_bh);
  1089. path[level].bp_bh = path[level].bp_sib_bh;
  1090. path[level].bp_sib_bh = NULL;
  1091. path[level].bp_index += nilfs_btree_node_get_nchildren(left);
  1092. }
  1093. static void nilfs_btree_concat_right(struct nilfs_btree *btree,
  1094. struct nilfs_btree_path *path,
  1095. int level, __u64 *keyp, __u64 *ptrp)
  1096. {
  1097. struct nilfs_btree_node *node, *right;
  1098. int n;
  1099. nilfs_btree_do_delete(btree, path, level, keyp, ptrp);
  1100. lock_buffer(path[level].bp_bh);
  1101. lock_buffer(path[level].bp_sib_bh);
  1102. node = nilfs_btree_get_nonroot_node(path, level);
  1103. right = nilfs_btree_get_sib_node(path, level);
  1104. n = nilfs_btree_node_get_nchildren(right);
  1105. nilfs_btree_node_move_left(btree, node, right, n);
  1106. if (!buffer_dirty(path[level].bp_bh))
  1107. nilfs_btnode_mark_dirty(path[level].bp_bh);
  1108. unlock_buffer(path[level].bp_bh);
  1109. unlock_buffer(path[level].bp_sib_bh);
  1110. nilfs_btnode_delete(path[level].bp_sib_bh);
  1111. path[level].bp_sib_bh = NULL;
  1112. path[level + 1].bp_index++;
  1113. }
  1114. static void nilfs_btree_shrink(struct nilfs_btree *btree,
  1115. struct nilfs_btree_path *path,
  1116. int level, __u64 *keyp, __u64 *ptrp)
  1117. {
  1118. struct nilfs_btree_node *root, *child;
  1119. int n;
  1120. nilfs_btree_do_delete(btree, path, level, keyp, ptrp);
  1121. lock_buffer(path[level].bp_bh);
  1122. root = nilfs_btree_get_root(btree);
  1123. child = nilfs_btree_get_nonroot_node(path, level);
  1124. nilfs_btree_node_delete(btree, root, NULL, NULL, 0);
  1125. nilfs_btree_node_set_level(root, level);
  1126. n = nilfs_btree_node_get_nchildren(child);
  1127. nilfs_btree_node_move_left(btree, root, child, n);
  1128. unlock_buffer(path[level].bp_bh);
  1129. nilfs_btnode_delete(path[level].bp_bh);
  1130. path[level].bp_bh = NULL;
  1131. }
  1132. static int nilfs_btree_prepare_delete(struct nilfs_btree *btree,
  1133. struct nilfs_btree_path *path,
  1134. int *levelp,
  1135. struct nilfs_bmap_stats *stats,
  1136. struct inode *dat)
  1137. {
  1138. struct buffer_head *bh;
  1139. struct nilfs_btree_node *node, *parent, *sib;
  1140. __u64 sibptr;
  1141. int pindex, level, ret;
  1142. ret = 0;
  1143. stats->bs_nblocks = 0;
  1144. for (level = NILFS_BTREE_LEVEL_NODE_MIN;
  1145. level < nilfs_btree_height(btree) - 1;
  1146. level++) {
  1147. node = nilfs_btree_get_nonroot_node(path, level);
  1148. path[level].bp_oldreq.bpr_ptr =
  1149. nilfs_btree_node_get_ptr(btree, node,
  1150. path[level].bp_index);
  1151. ret = nilfs_bmap_prepare_end_ptr(&btree->bt_bmap,
  1152. &path[level].bp_oldreq, dat);
  1153. if (ret < 0)
  1154. goto err_out_child_node;
  1155. if (nilfs_btree_node_get_nchildren(node) >
  1156. nilfs_btree_node_nchildren_min(node, btree)) {
  1157. path[level].bp_op = nilfs_btree_do_delete;
  1158. stats->bs_nblocks++;
  1159. goto out;
  1160. }
  1161. parent = nilfs_btree_get_node(btree, path, level + 1);
  1162. pindex = path[level + 1].bp_index;
  1163. if (pindex > 0) {
  1164. /* left sibling */
  1165. sibptr = nilfs_btree_node_get_ptr(btree, parent,
  1166. pindex - 1);
  1167. ret = nilfs_btree_get_block(btree, sibptr, &bh);
  1168. if (ret < 0)
  1169. goto err_out_curr_node;
  1170. sib = (struct nilfs_btree_node *)bh->b_data;
  1171. if (nilfs_btree_node_get_nchildren(sib) >
  1172. nilfs_btree_node_nchildren_min(sib, btree)) {
  1173. path[level].bp_sib_bh = bh;
  1174. path[level].bp_op = nilfs_btree_borrow_left;
  1175. stats->bs_nblocks++;
  1176. goto out;
  1177. } else {
  1178. path[level].bp_sib_bh = bh;
  1179. path[level].bp_op = nilfs_btree_concat_left;
  1180. stats->bs_nblocks++;
  1181. /* continue; */
  1182. }
  1183. } else if (pindex <
  1184. nilfs_btree_node_get_nchildren(parent) - 1) {
  1185. /* right sibling */
  1186. sibptr = nilfs_btree_node_get_ptr(btree, parent,
  1187. pindex + 1);
  1188. ret = nilfs_btree_get_block(btree, sibptr, &bh);
  1189. if (ret < 0)
  1190. goto err_out_curr_node;
  1191. sib = (struct nilfs_btree_node *)bh->b_data;
  1192. if (nilfs_btree_node_get_nchildren(sib) >
  1193. nilfs_btree_node_nchildren_min(sib, btree)) {
  1194. path[level].bp_sib_bh = bh;
  1195. path[level].bp_op = nilfs_btree_borrow_right;
  1196. stats->bs_nblocks++;
  1197. goto out;
  1198. } else {
  1199. path[level].bp_sib_bh = bh;
  1200. path[level].bp_op = nilfs_btree_concat_right;
  1201. stats->bs_nblocks++;
  1202. /* continue; */
  1203. }
  1204. } else {
  1205. /* no siblings */
  1206. /* the only child of the root node */
  1207. WARN_ON(level != nilfs_btree_height(btree) - 2);
  1208. if (nilfs_btree_node_get_nchildren(node) - 1 <=
  1209. NILFS_BTREE_ROOT_NCHILDREN_MAX) {
  1210. path[level].bp_op = nilfs_btree_shrink;
  1211. stats->bs_nblocks += 2;
  1212. } else {
  1213. path[level].bp_op = nilfs_btree_do_delete;
  1214. stats->bs_nblocks++;
  1215. }
  1216. goto out;
  1217. }
  1218. }
  1219. node = nilfs_btree_get_root(btree);
  1220. path[level].bp_oldreq.bpr_ptr =
  1221. nilfs_btree_node_get_ptr(btree, node, path[level].bp_index);
  1222. ret = nilfs_bmap_prepare_end_ptr(&btree->bt_bmap,
  1223. &path[level].bp_oldreq, dat);
  1224. if (ret < 0)
  1225. goto err_out_child_node;
  1226. /* child of the root node is deleted */
  1227. path[level].bp_op = nilfs_btree_do_delete;
  1228. stats->bs_nblocks++;
  1229. /* success */
  1230. out:
  1231. *levelp = level;
  1232. return ret;
  1233. /* error */
  1234. err_out_curr_node:
  1235. nilfs_bmap_abort_end_ptr(&btree->bt_bmap, &path[level].bp_oldreq, dat);
  1236. err_out_child_node:
  1237. for (level--; level >= NILFS_BTREE_LEVEL_NODE_MIN; level--) {
  1238. brelse(path[level].bp_sib_bh);
  1239. nilfs_bmap_abort_end_ptr(&btree->bt_bmap,
  1240. &path[level].bp_oldreq, dat);
  1241. }
  1242. *levelp = level;
  1243. stats->bs_nblocks = 0;
  1244. return ret;
  1245. }
  1246. static void nilfs_btree_commit_delete(struct nilfs_btree *btree,
  1247. struct nilfs_btree_path *path,
  1248. int maxlevel, struct inode *dat)
  1249. {
  1250. int level;
  1251. for (level = NILFS_BTREE_LEVEL_NODE_MIN; level <= maxlevel; level++) {
  1252. nilfs_bmap_commit_end_ptr(&btree->bt_bmap,
  1253. &path[level].bp_oldreq, dat);
  1254. path[level].bp_op(btree, path, level, NULL, NULL);
  1255. }
  1256. if (!nilfs_bmap_dirty(&btree->bt_bmap))
  1257. nilfs_bmap_set_dirty(&btree->bt_bmap);
  1258. }
  1259. static int nilfs_btree_delete(struct nilfs_bmap *bmap, __u64 key)
  1260. {
  1261. struct nilfs_btree *btree;
  1262. struct nilfs_btree_path *path;
  1263. struct nilfs_bmap_stats stats;
  1264. struct inode *dat;
  1265. int level, ret;
  1266. btree = (struct nilfs_btree *)bmap;
  1267. path = nilfs_btree_alloc_path();
  1268. if (path == NULL)
  1269. return -ENOMEM;
  1270. nilfs_btree_init_path(path);
  1271. ret = nilfs_btree_do_lookup(btree, path, key, NULL,
  1272. NILFS_BTREE_LEVEL_NODE_MIN);
  1273. if (ret < 0)
  1274. goto out;
  1275. dat = NILFS_BMAP_USE_VBN(&btree->bt_bmap) ?
  1276. nilfs_bmap_get_dat(&btree->bt_bmap) : NULL;
  1277. ret = nilfs_btree_prepare_delete(btree, path, &level, &stats, dat);
  1278. if (ret < 0)
  1279. goto out;
  1280. nilfs_btree_commit_delete(btree, path, level, dat);
  1281. nilfs_bmap_sub_blocks(bmap, stats.bs_nblocks);
  1282. out:
  1283. nilfs_btree_release_path(path);
  1284. nilfs_btree_free_path(path);
  1285. return ret;
  1286. }
  1287. static int nilfs_btree_last_key(const struct nilfs_bmap *bmap, __u64 *keyp)
  1288. {
  1289. struct nilfs_btree *btree;
  1290. struct nilfs_btree_path *path;
  1291. int ret;
  1292. btree = (struct nilfs_btree *)bmap;
  1293. path = nilfs_btree_alloc_path();
  1294. if (path == NULL)
  1295. return -ENOMEM;
  1296. nilfs_btree_init_path(path);
  1297. ret = nilfs_btree_do_lookup_last(btree, path, keyp, NULL);
  1298. nilfs_btree_release_path(path);
  1299. nilfs_btree_free_path(path);
  1300. return ret;
  1301. }
  1302. static int nilfs_btree_check_delete(struct nilfs_bmap *bmap, __u64 key)
  1303. {
  1304. struct buffer_head *bh;
  1305. struct nilfs_btree *btree;
  1306. struct nilfs_btree_node *root, *node;
  1307. __u64 maxkey, nextmaxkey;
  1308. __u64 ptr;
  1309. int nchildren, ret;
  1310. btree = (struct nilfs_btree *)bmap;
  1311. root = nilfs_btree_get_root(btree);
  1312. switch (nilfs_btree_height(btree)) {
  1313. case 2:
  1314. bh = NULL;
  1315. node = root;
  1316. break;
  1317. case 3:
  1318. nchildren = nilfs_btree_node_get_nchildren(root);
  1319. if (nchildren > 1)
  1320. return 0;
  1321. ptr = nilfs_btree_node_get_ptr(btree, root, nchildren - 1);
  1322. ret = nilfs_btree_get_block(btree, ptr, &bh);
  1323. if (ret < 0)
  1324. return ret;
  1325. node = (struct nilfs_btree_node *)bh->b_data;
  1326. break;
  1327. default:
  1328. return 0;
  1329. }
  1330. nchildren = nilfs_btree_node_get_nchildren(node);
  1331. maxkey = nilfs_btree_node_get_key(node, nchildren - 1);
  1332. nextmaxkey = (nchildren > 1) ?
  1333. nilfs_btree_node_get_key(node, nchildren - 2) : 0;
  1334. if (bh != NULL)
  1335. brelse(bh);
  1336. return (maxkey == key) && (nextmaxkey < NILFS_BMAP_LARGE_LOW);
  1337. }
  1338. static int nilfs_btree_gather_data(struct nilfs_bmap *bmap,
  1339. __u64 *keys, __u64 *ptrs, int nitems)
  1340. {
  1341. struct buffer_head *bh;
  1342. struct nilfs_btree *btree;
  1343. struct nilfs_btree_node *node, *root;
  1344. __le64 *dkeys;
  1345. __le64 *dptrs;
  1346. __u64 ptr;
  1347. int nchildren, i, ret;
  1348. btree = (struct nilfs_btree *)bmap;
  1349. root = nilfs_btree_get_root(btree);
  1350. switch (nilfs_btree_height(btree)) {
  1351. case 2:
  1352. bh = NULL;
  1353. node = root;
  1354. break;
  1355. case 3:
  1356. nchildren = nilfs_btree_node_get_nchildren(root);
  1357. WARN_ON(nchildren > 1);
  1358. ptr = nilfs_btree_node_get_ptr(btree, root, nchildren - 1);
  1359. ret = nilfs_btree_get_block(btree, ptr, &bh);
  1360. if (ret < 0)
  1361. return ret;
  1362. node = (struct nilfs_btree_node *)bh->b_data;
  1363. break;
  1364. default:
  1365. node = NULL;
  1366. return -EINVAL;
  1367. }
  1368. nchildren = nilfs_btree_node_get_nchildren(node);
  1369. if (nchildren < nitems)
  1370. nitems = nchildren;
  1371. dkeys = nilfs_btree_node_dkeys(node);
  1372. dptrs = nilfs_btree_node_dptrs(node, btree);
  1373. for (i = 0; i < nitems; i++) {
  1374. keys[i] = nilfs_bmap_dkey_to_key(dkeys[i]);
  1375. ptrs[i] = nilfs_bmap_dptr_to_ptr(dptrs[i]);
  1376. }
  1377. if (bh != NULL)
  1378. brelse(bh);
  1379. return nitems;
  1380. }
  1381. static int
  1382. nilfs_btree_prepare_convert_and_insert(struct nilfs_bmap *bmap, __u64 key,
  1383. union nilfs_bmap_ptr_req *dreq,
  1384. union nilfs_bmap_ptr_req *nreq,
  1385. struct buffer_head **bhp,
  1386. struct nilfs_bmap_stats *stats)
  1387. {
  1388. struct buffer_head *bh;
  1389. struct nilfs_btree *btree = (struct nilfs_btree *)bmap;
  1390. struct inode *dat = NULL;
  1391. int ret;
  1392. stats->bs_nblocks = 0;
  1393. /* for data */
  1394. /* cannot find near ptr */
  1395. if (NILFS_BMAP_USE_VBN(bmap)) {
  1396. dreq->bpr_ptr = nilfs_btree_find_target_v(btree, NULL, key);
  1397. dat = nilfs_bmap_get_dat(bmap);
  1398. }
  1399. ret = nilfs_bmap_prepare_alloc_ptr(bmap, dreq, dat);
  1400. if (ret < 0)
  1401. return ret;
  1402. *bhp = NULL;
  1403. stats->bs_nblocks++;
  1404. if (nreq != NULL) {
  1405. nreq->bpr_ptr = dreq->bpr_ptr + 1;
  1406. ret = nilfs_bmap_prepare_alloc_ptr(bmap, nreq, dat);
  1407. if (ret < 0)
  1408. goto err_out_dreq;
  1409. ret = nilfs_btree_get_new_block(btree, nreq->bpr_ptr, &bh);
  1410. if (ret < 0)
  1411. goto err_out_nreq;
  1412. *bhp = bh;
  1413. stats->bs_nblocks++;
  1414. }
  1415. /* success */
  1416. return 0;
  1417. /* error */
  1418. err_out_nreq:
  1419. nilfs_bmap_abort_alloc_ptr(bmap, nreq, dat);
  1420. err_out_dreq:
  1421. nilfs_bmap_abort_alloc_ptr(bmap, dreq, dat);
  1422. stats->bs_nblocks = 0;
  1423. return ret;
  1424. }
  1425. static void
  1426. nilfs_btree_commit_convert_and_insert(struct nilfs_bmap *bmap,
  1427. __u64 key, __u64 ptr,
  1428. const __u64 *keys, const __u64 *ptrs,
  1429. int n,
  1430. union nilfs_bmap_ptr_req *dreq,
  1431. union nilfs_bmap_ptr_req *nreq,
  1432. struct buffer_head *bh)
  1433. {
  1434. struct nilfs_btree *btree = (struct nilfs_btree *)bmap;
  1435. struct nilfs_btree_node *node;
  1436. struct inode *dat;
  1437. __u64 tmpptr;
  1438. /* free resources */
  1439. if (bmap->b_ops->bop_clear != NULL)
  1440. bmap->b_ops->bop_clear(bmap);
  1441. /* ptr must be a pointer to a buffer head. */
  1442. set_buffer_nilfs_volatile((struct buffer_head *)((unsigned long)ptr));
  1443. /* convert and insert */
  1444. dat = NILFS_BMAP_USE_VBN(bmap) ? nilfs_bmap_get_dat(bmap) : NULL;
  1445. nilfs_btree_init(bmap);
  1446. if (nreq != NULL) {
  1447. nilfs_bmap_commit_alloc_ptr(bmap, dreq, dat);
  1448. nilfs_bmap_commit_alloc_ptr(bmap, nreq, dat);
  1449. /* create child node at level 1 */
  1450. lock_buffer(bh);
  1451. node = (struct nilfs_btree_node *)bh->b_data;
  1452. nilfs_btree_node_init(btree, node, 0, 1, n, keys, ptrs);
  1453. nilfs_btree_node_insert(btree, node,
  1454. key, dreq->bpr_ptr, n);
  1455. if (!buffer_dirty(bh))
  1456. nilfs_btnode_mark_dirty(bh);
  1457. if (!nilfs_bmap_dirty(bmap))
  1458. nilfs_bmap_set_dirty(bmap);
  1459. unlock_buffer(bh);
  1460. brelse(bh);
  1461. /* create root node at level 2 */
  1462. node = nilfs_btree_get_root(btree);
  1463. tmpptr = nreq->bpr_ptr;
  1464. nilfs_btree_node_init(btree, node, NILFS_BTREE_NODE_ROOT,
  1465. 2, 1, &keys[0], &tmpptr);
  1466. } else {
  1467. nilfs_bmap_commit_alloc_ptr(bmap, dreq, dat);
  1468. /* create root node at level 1 */
  1469. node = nilfs_btree_get_root(btree);
  1470. nilfs_btree_node_init(btree, node, NILFS_BTREE_NODE_ROOT,
  1471. 1, n, keys, ptrs);
  1472. nilfs_btree_node_insert(btree, node,
  1473. key, dreq->bpr_ptr, n);
  1474. if (!nilfs_bmap_dirty(bmap))
  1475. nilfs_bmap_set_dirty(bmap);
  1476. }
  1477. if (NILFS_BMAP_USE_VBN(bmap))
  1478. nilfs_btree_set_target_v(btree, key, dreq->bpr_ptr);
  1479. }
  1480. /**
  1481. * nilfs_btree_convert_and_insert -
  1482. * @bmap:
  1483. * @key:
  1484. * @ptr:
  1485. * @keys:
  1486. * @ptrs:
  1487. * @n:
  1488. */
  1489. int nilfs_btree_convert_and_insert(struct nilfs_bmap *bmap,
  1490. __u64 key, __u64 ptr,
  1491. const __u64 *keys, const __u64 *ptrs, int n)
  1492. {
  1493. struct buffer_head *bh;
  1494. union nilfs_bmap_ptr_req dreq, nreq, *di, *ni;
  1495. struct nilfs_bmap_stats stats;
  1496. int ret;
  1497. if (n + 1 <= NILFS_BTREE_ROOT_NCHILDREN_MAX) {
  1498. di = &dreq;
  1499. ni = NULL;
  1500. } else if ((n + 1) <= NILFS_BTREE_NODE_NCHILDREN_MAX(
  1501. 1 << bmap->b_inode->i_blkbits)) {
  1502. di = &dreq;
  1503. ni = &nreq;
  1504. } else {
  1505. di = NULL;
  1506. ni = NULL;
  1507. BUG();
  1508. }
  1509. ret = nilfs_btree_prepare_convert_and_insert(bmap, key, di, ni, &bh,
  1510. &stats);
  1511. if (ret < 0)
  1512. return ret;
  1513. nilfs_btree_commit_convert_and_insert(bmap, key, ptr, keys, ptrs, n,
  1514. di, ni, bh);
  1515. nilfs_bmap_add_blocks(bmap, stats.bs_nblocks);
  1516. return 0;
  1517. }
  1518. static int nilfs_btree_propagate_p(struct nilfs_btree *btree,
  1519. struct nilfs_btree_path *path,
  1520. int level,
  1521. struct buffer_head *bh)
  1522. {
  1523. while ((++level < nilfs_btree_height(btree) - 1) &&
  1524. !buffer_dirty(path[level].bp_bh))
  1525. nilfs_btnode_mark_dirty(path[level].bp_bh);
  1526. return 0;
  1527. }
  1528. static int nilfs_btree_prepare_update_v(struct nilfs_btree *btree,
  1529. struct nilfs_btree_path *path,
  1530. int level, struct inode *dat)
  1531. {
  1532. struct nilfs_btree_node *parent;
  1533. int ret;
  1534. parent = nilfs_btree_get_node(btree, path, level + 1);
  1535. path[level].bp_oldreq.bpr_ptr =
  1536. nilfs_btree_node_get_ptr(btree, parent,
  1537. path[level + 1].bp_index);
  1538. path[level].bp_newreq.bpr_ptr = path[level].bp_oldreq.bpr_ptr + 1;
  1539. ret = nilfs_dat_prepare_update(dat, &path[level].bp_oldreq.bpr_req,
  1540. &path[level].bp_newreq.bpr_req);
  1541. if (ret < 0)
  1542. return ret;
  1543. if (buffer_nilfs_node(path[level].bp_bh)) {
  1544. path[level].bp_ctxt.oldkey = path[level].bp_oldreq.bpr_ptr;
  1545. path[level].bp_ctxt.newkey = path[level].bp_newreq.bpr_ptr;
  1546. path[level].bp_ctxt.bh = path[level].bp_bh;
  1547. ret = nilfs_btnode_prepare_change_key(
  1548. &NILFS_BMAP_I(&btree->bt_bmap)->i_btnode_cache,
  1549. &path[level].bp_ctxt);
  1550. if (ret < 0) {
  1551. nilfs_dat_abort_update(dat,
  1552. &path[level].bp_oldreq.bpr_req,
  1553. &path[level].bp_newreq.bpr_req);
  1554. return ret;
  1555. }
  1556. }
  1557. return 0;
  1558. }
  1559. static void nilfs_btree_commit_update_v(struct nilfs_btree *btree,
  1560. struct nilfs_btree_path *path,
  1561. int level, struct inode *dat)
  1562. {
  1563. struct nilfs_btree_node *parent;
  1564. nilfs_dat_commit_update(dat, &path[level].bp_oldreq.bpr_req,
  1565. &path[level].bp_newreq.bpr_req,
  1566. btree->bt_bmap.b_ptr_type == NILFS_BMAP_PTR_VS);
  1567. if (buffer_nilfs_node(path[level].bp_bh)) {
  1568. nilfs_btnode_commit_change_key(
  1569. &NILFS_BMAP_I(&btree->bt_bmap)->i_btnode_cache,
  1570. &path[level].bp_ctxt);
  1571. path[level].bp_bh = path[level].bp_ctxt.bh;
  1572. }
  1573. set_buffer_nilfs_volatile(path[level].bp_bh);
  1574. parent = nilfs_btree_get_node(btree, path, level + 1);
  1575. nilfs_btree_node_set_ptr(btree, parent, path[level + 1].bp_index,
  1576. path[level].bp_newreq.bpr_ptr);
  1577. }
  1578. static void nilfs_btree_abort_update_v(struct nilfs_btree *btree,
  1579. struct nilfs_btree_path *path,
  1580. int level, struct inode *dat)
  1581. {
  1582. nilfs_dat_abort_update(dat, &path[level].bp_oldreq.bpr_req,
  1583. &path[level].bp_newreq.bpr_req);
  1584. if (buffer_nilfs_node(path[level].bp_bh))
  1585. nilfs_btnode_abort_change_key(
  1586. &NILFS_BMAP_I(&btree->bt_bmap)->i_btnode_cache,
  1587. &path[level].bp_ctxt);
  1588. }
  1589. static int nilfs_btree_prepare_propagate_v(struct nilfs_btree *btree,
  1590. struct nilfs_btree_path *path,
  1591. int minlevel, int *maxlevelp,
  1592. struct inode *dat)
  1593. {
  1594. int level, ret;
  1595. level = minlevel;
  1596. if (!buffer_nilfs_volatile(path[level].bp_bh)) {
  1597. ret = nilfs_btree_prepare_update_v(btree, path, level, dat);
  1598. if (ret < 0)
  1599. return ret;
  1600. }
  1601. while ((++level < nilfs_btree_height(btree) - 1) &&
  1602. !buffer_dirty(path[level].bp_bh)) {
  1603. WARN_ON(buffer_nilfs_volatile(path[level].bp_bh));
  1604. ret = nilfs_btree_prepare_update_v(btree, path, level, dat);
  1605. if (ret < 0)
  1606. goto out;
  1607. }
  1608. /* success */
  1609. *maxlevelp = level - 1;
  1610. return 0;
  1611. /* error */
  1612. out:
  1613. while (--level > minlevel)
  1614. nilfs_btree_abort_update_v(btree, path, level, dat);
  1615. if (!buffer_nilfs_volatile(path[level].bp_bh))
  1616. nilfs_btree_abort_update_v(btree, path, level, dat);
  1617. return ret;
  1618. }
  1619. static void nilfs_btree_commit_propagate_v(struct nilfs_btree *btree,
  1620. struct nilfs_btree_path *path,
  1621. int minlevel, int maxlevel,
  1622. struct buffer_head *bh,
  1623. struct inode *dat)
  1624. {
  1625. int level;
  1626. if (!buffer_nilfs_volatile(path[minlevel].bp_bh))
  1627. nilfs_btree_commit_update_v(btree, path, minlevel, dat);
  1628. for (level = minlevel + 1; level <= maxlevel; level++)
  1629. nilfs_btree_commit_update_v(btree, path, level, dat);
  1630. }
  1631. static int nilfs_btree_propagate_v(struct nilfs_btree *btree,
  1632. struct nilfs_btree_path *path,
  1633. int level, struct buffer_head *bh)
  1634. {
  1635. int maxlevel, ret;
  1636. struct nilfs_btree_node *parent;
  1637. struct inode *dat = nilfs_bmap_get_dat(&btree->bt_bmap);
  1638. __u64 ptr;
  1639. get_bh(bh);
  1640. path[level].bp_bh = bh;
  1641. ret = nilfs_btree_prepare_propagate_v(btree, path, level, &maxlevel,
  1642. dat);
  1643. if (ret < 0)
  1644. goto out;
  1645. if (buffer_nilfs_volatile(path[level].bp_bh)) {
  1646. parent = nilfs_btree_get_node(btree, path, level + 1);
  1647. ptr = nilfs_btree_node_get_ptr(btree, parent,
  1648. path[level + 1].bp_index);
  1649. ret = nilfs_dat_mark_dirty(dat, ptr);
  1650. if (ret < 0)
  1651. goto out;
  1652. }
  1653. nilfs_btree_commit_propagate_v(btree, path, level, maxlevel, bh, dat);
  1654. out:
  1655. brelse(path[level].bp_bh);
  1656. path[level].bp_bh = NULL;
  1657. return ret;
  1658. }
  1659. static int nilfs_btree_propagate(const struct nilfs_bmap *bmap,
  1660. struct buffer_head *bh)
  1661. {
  1662. struct nilfs_btree *btree;
  1663. struct nilfs_btree_path *path;
  1664. struct nilfs_btree_node *node;
  1665. __u64 key;
  1666. int level, ret;
  1667. WARN_ON(!buffer_dirty(bh));
  1668. btree = (struct nilfs_btree *)bmap;
  1669. path = nilfs_btree_alloc_path();
  1670. if (path == NULL)
  1671. return -ENOMEM;
  1672. nilfs_btree_init_path(path);
  1673. if (buffer_nilfs_node(bh)) {
  1674. node = (struct nilfs_btree_node *)bh->b_data;
  1675. key = nilfs_btree_node_get_key(node, 0);
  1676. level = nilfs_btree_node_get_level(node);
  1677. } else {
  1678. key = nilfs_bmap_data_get_key(bmap, bh);
  1679. level = NILFS_BTREE_LEVEL_DATA;
  1680. }
  1681. ret = nilfs_btree_do_lookup(btree, path, key, NULL, level + 1);
  1682. if (ret < 0) {
  1683. if (unlikely(ret == -ENOENT))
  1684. printk(KERN_CRIT "%s: key = %llu, level == %d\n",
  1685. __func__, (unsigned long long)key, level);
  1686. goto out;
  1687. }
  1688. ret = NILFS_BMAP_USE_VBN(bmap) ?
  1689. nilfs_btree_propagate_v(btree, path, level, bh) :
  1690. nilfs_btree_propagate_p(btree, path, level, bh);
  1691. out:
  1692. nilfs_btree_release_path(path);
  1693. nilfs_btree_free_path(path);
  1694. return ret;
  1695. }
  1696. static int nilfs_btree_propagate_gc(const struct nilfs_bmap *bmap,
  1697. struct buffer_head *bh)
  1698. {
  1699. return nilfs_dat_mark_dirty(nilfs_bmap_get_dat(bmap), bh->b_blocknr);
  1700. }
  1701. static void nilfs_btree_add_dirty_buffer(struct nilfs_btree *btree,
  1702. struct list_head *lists,
  1703. struct buffer_head *bh)
  1704. {
  1705. struct list_head *head;
  1706. struct buffer_head *cbh;
  1707. struct nilfs_btree_node *node, *cnode;
  1708. __u64 key, ckey;
  1709. int level;
  1710. get_bh(bh);
  1711. node = (struct nilfs_btree_node *)bh->b_data;
  1712. key = nilfs_btree_node_get_key(node, 0);
  1713. level = nilfs_btree_node_get_level(node);
  1714. list_for_each(head, &lists[level]) {
  1715. cbh = list_entry(head, struct buffer_head, b_assoc_buffers);
  1716. cnode = (struct nilfs_btree_node *)cbh->b_data;
  1717. ckey = nilfs_btree_node_get_key(cnode, 0);
  1718. if (key < ckey)
  1719. break;
  1720. }
  1721. list_add_tail(&bh->b_assoc_buffers, head);
  1722. }
  1723. static void nilfs_btree_lookup_dirty_buffers(struct nilfs_bmap *bmap,
  1724. struct list_head *listp)
  1725. {
  1726. struct nilfs_btree *btree = (struct nilfs_btree *)bmap;
  1727. struct address_space *btcache = &NILFS_BMAP_I(bmap)->i_btnode_cache;
  1728. struct list_head lists[NILFS_BTREE_LEVEL_MAX];
  1729. struct pagevec pvec;
  1730. struct buffer_head *bh, *head;
  1731. pgoff_t index = 0;
  1732. int level, i;
  1733. for (level = NILFS_BTREE_LEVEL_NODE_MIN;
  1734. level < NILFS_BTREE_LEVEL_MAX;
  1735. level++)
  1736. INIT_LIST_HEAD(&lists[level]);
  1737. pagevec_init(&pvec, 0);
  1738. while (pagevec_lookup_tag(&pvec, btcache, &index, PAGECACHE_TAG_DIRTY,
  1739. PAGEVEC_SIZE)) {
  1740. for (i = 0; i < pagevec_count(&pvec); i++) {
  1741. bh = head = page_buffers(pvec.pages[i]);
  1742. do {
  1743. if (buffer_dirty(bh))
  1744. nilfs_btree_add_dirty_buffer(btree,
  1745. lists, bh);
  1746. } while ((bh = bh->b_this_page) != head);
  1747. }
  1748. pagevec_release(&pvec);
  1749. cond_resched();
  1750. }
  1751. for (level = NILFS_BTREE_LEVEL_NODE_MIN;
  1752. level < NILFS_BTREE_LEVEL_MAX;
  1753. level++)
  1754. list_splice(&lists[level], listp->prev);
  1755. }
  1756. static int nilfs_btree_assign_p(struct nilfs_btree *btree,
  1757. struct nilfs_btree_path *path,
  1758. int level,
  1759. struct buffer_head **bh,
  1760. sector_t blocknr,
  1761. union nilfs_binfo *binfo)
  1762. {
  1763. struct nilfs_btree_node *parent;
  1764. __u64 key;
  1765. __u64 ptr;
  1766. int ret;
  1767. parent = nilfs_btree_get_node(btree, path, level + 1);
  1768. ptr = nilfs_btree_node_get_ptr(btree, parent,
  1769. path[level + 1].bp_index);
  1770. if (buffer_nilfs_node(*bh)) {
  1771. path[level].bp_ctxt.oldkey = ptr;
  1772. path[level].bp_ctxt.newkey = blocknr;
  1773. path[level].bp_ctxt.bh = *bh;
  1774. ret = nilfs_btnode_prepare_change_key(
  1775. &NILFS_BMAP_I(&btree->bt_bmap)->i_btnode_cache,
  1776. &path[level].bp_ctxt);
  1777. if (ret < 0)
  1778. return ret;
  1779. nilfs_btnode_commit_change_key(
  1780. &NILFS_BMAP_I(&btree->bt_bmap)->i_btnode_cache,
  1781. &path[level].bp_ctxt);
  1782. *bh = path[level].bp_ctxt.bh;
  1783. }
  1784. nilfs_btree_node_set_ptr(btree, parent,
  1785. path[level + 1].bp_index, blocknr);
  1786. key = nilfs_btree_node_get_key(parent, path[level + 1].bp_index);
  1787. /* on-disk format */
  1788. binfo->bi_dat.bi_blkoff = nilfs_bmap_key_to_dkey(key);
  1789. binfo->bi_dat.bi_level = level;
  1790. return 0;
  1791. }
  1792. static int nilfs_btree_assign_v(struct nilfs_btree *btree,
  1793. struct nilfs_btree_path *path,
  1794. int level,
  1795. struct buffer_head **bh,
  1796. sector_t blocknr,
  1797. union nilfs_binfo *binfo)
  1798. {
  1799. struct nilfs_btree_node *parent;
  1800. struct inode *dat = nilfs_bmap_get_dat(&btree->bt_bmap);
  1801. __u64 key;
  1802. __u64 ptr;
  1803. union nilfs_bmap_ptr_req req;
  1804. int ret;
  1805. parent = nilfs_btree_get_node(btree, path, level + 1);
  1806. ptr = nilfs_btree_node_get_ptr(btree, parent,
  1807. path[level + 1].bp_index);
  1808. req.bpr_ptr = ptr;
  1809. ret = nilfs_dat_prepare_start(dat, &req.bpr_req);
  1810. if (ret < 0)
  1811. return ret;
  1812. nilfs_dat_commit_start(dat, &req.bpr_req, blocknr);
  1813. key = nilfs_btree_node_get_key(parent, path[level + 1].bp_index);
  1814. /* on-disk format */
  1815. binfo->bi_v.bi_vblocknr = nilfs_bmap_ptr_to_dptr(ptr);
  1816. binfo->bi_v.bi_blkoff = nilfs_bmap_key_to_dkey(key);
  1817. return 0;
  1818. }
  1819. static int nilfs_btree_assign(struct nilfs_bmap *bmap,
  1820. struct buffer_head **bh,
  1821. sector_t blocknr,
  1822. union nilfs_binfo *binfo)
  1823. {
  1824. struct nilfs_btree *btree;
  1825. struct nilfs_btree_path *path;
  1826. struct nilfs_btree_node *node;
  1827. __u64 key;
  1828. int level, ret;
  1829. btree = (struct nilfs_btree *)bmap;
  1830. path = nilfs_btree_alloc_path();
  1831. if (path == NULL)
  1832. return -ENOMEM;
  1833. nilfs_btree_init_path(path);
  1834. if (buffer_nilfs_node(*bh)) {
  1835. node = (struct nilfs_btree_node *)(*bh)->b_data;
  1836. key = nilfs_btree_node_get_key(node, 0);
  1837. level = nilfs_btree_node_get_level(node);
  1838. } else {
  1839. key = nilfs_bmap_data_get_key(bmap, *bh);
  1840. level = NILFS_BTREE_LEVEL_DATA;
  1841. }
  1842. ret = nilfs_btree_do_lookup(btree, path, key, NULL, level + 1);
  1843. if (ret < 0) {
  1844. WARN_ON(ret == -ENOENT);
  1845. goto out;
  1846. }
  1847. ret = NILFS_BMAP_USE_VBN(bmap) ?
  1848. nilfs_btree_assign_v(btree, path, level, bh, blocknr, binfo) :
  1849. nilfs_btree_assign_p(btree, path, level, bh, blocknr, binfo);
  1850. out:
  1851. nilfs_btree_release_path(path);
  1852. nilfs_btree_free_path(path);
  1853. return ret;
  1854. }
  1855. static int nilfs_btree_assign_gc(struct nilfs_bmap *bmap,
  1856. struct buffer_head **bh,
  1857. sector_t blocknr,
  1858. union nilfs_binfo *binfo)
  1859. {
  1860. struct nilfs_btree_node *node;
  1861. __u64 key;
  1862. int ret;
  1863. ret = nilfs_dat_move(nilfs_bmap_get_dat(bmap), (*bh)->b_blocknr,
  1864. blocknr);
  1865. if (ret < 0)
  1866. return ret;
  1867. if (buffer_nilfs_node(*bh)) {
  1868. node = (struct nilfs_btree_node *)(*bh)->b_data;
  1869. key = nilfs_btree_node_get_key(node, 0);
  1870. } else
  1871. key = nilfs_bmap_data_get_key(bmap, *bh);
  1872. /* on-disk format */
  1873. binfo->bi_v.bi_vblocknr = cpu_to_le64((*bh)->b_blocknr);
  1874. binfo->bi_v.bi_blkoff = nilfs_bmap_key_to_dkey(key);
  1875. return 0;
  1876. }
  1877. static int nilfs_btree_mark(struct nilfs_bmap *bmap, __u64 key, int level)
  1878. {
  1879. struct buffer_head *bh;
  1880. struct nilfs_btree *btree;
  1881. struct nilfs_btree_path *path;
  1882. __u64 ptr;
  1883. int ret;
  1884. btree = (struct nilfs_btree *)bmap;
  1885. path = nilfs_btree_alloc_path();
  1886. if (path == NULL)
  1887. return -ENOMEM;
  1888. nilfs_btree_init_path(path);
  1889. ret = nilfs_btree_do_lookup(btree, path, key, &ptr, level + 1);
  1890. if (ret < 0) {
  1891. WARN_ON(ret == -ENOENT);
  1892. goto out;
  1893. }
  1894. ret = nilfs_btree_get_block(btree, ptr, &bh);
  1895. if (ret < 0) {
  1896. WARN_ON(ret == -ENOENT);
  1897. goto out;
  1898. }
  1899. if (!buffer_dirty(bh))
  1900. nilfs_btnode_mark_dirty(bh);
  1901. brelse(bh);
  1902. if (!nilfs_bmap_dirty(&btree->bt_bmap))
  1903. nilfs_bmap_set_dirty(&btree->bt_bmap);
  1904. out:
  1905. nilfs_btree_release_path(path);
  1906. nilfs_btree_free_path(path);
  1907. return ret;
  1908. }
  1909. static const struct nilfs_bmap_operations nilfs_btree_ops = {
  1910. .bop_lookup = nilfs_btree_lookup,
  1911. .bop_lookup_contig = nilfs_btree_lookup_contig,
  1912. .bop_insert = nilfs_btree_insert,
  1913. .bop_delete = nilfs_btree_delete,
  1914. .bop_clear = NULL,
  1915. .bop_propagate = nilfs_btree_propagate,
  1916. .bop_lookup_dirty_buffers = nilfs_btree_lookup_dirty_buffers,
  1917. .bop_assign = nilfs_btree_assign,
  1918. .bop_mark = nilfs_btree_mark,
  1919. .bop_last_key = nilfs_btree_last_key,
  1920. .bop_check_insert = NULL,
  1921. .bop_check_delete = nilfs_btree_check_delete,
  1922. .bop_gather_data = nilfs_btree_gather_data,
  1923. };
  1924. static const struct nilfs_bmap_operations nilfs_btree_ops_gc = {
  1925. .bop_lookup = NULL,
  1926. .bop_lookup_contig = NULL,
  1927. .bop_insert = NULL,
  1928. .bop_delete = NULL,
  1929. .bop_clear = NULL,
  1930. .bop_propagate = nilfs_btree_propagate_gc,
  1931. .bop_lookup_dirty_buffers = nilfs_btree_lookup_dirty_buffers,
  1932. .bop_assign = nilfs_btree_assign_gc,
  1933. .bop_mark = NULL,
  1934. .bop_last_key = NULL,
  1935. .bop_check_insert = NULL,
  1936. .bop_check_delete = NULL,
  1937. .bop_gather_data = NULL,
  1938. };
  1939. int nilfs_btree_init(struct nilfs_bmap *bmap)
  1940. {
  1941. bmap->b_ops = &nilfs_btree_ops;
  1942. return 0;
  1943. }
  1944. void nilfs_btree_init_gc(struct nilfs_bmap *bmap)
  1945. {
  1946. bmap->b_ops = &nilfs_btree_ops_gc;
  1947. }