btree.c 58 KB

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