btree.c 62 KB

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