xfs_bmap_btree.c 60 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182
  1. /*
  2. * Copyright (c) 2000-2003,2005 Silicon Graphics, Inc.
  3. * All Rights Reserved.
  4. *
  5. * This program is free software; you can redistribute it and/or
  6. * modify it under the terms of the GNU General Public License as
  7. * published by the Free Software Foundation.
  8. *
  9. * This program is distributed in the hope that it would be useful,
  10. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  12. * GNU General Public License for more details.
  13. *
  14. * You should have received a copy of the GNU General Public License
  15. * along with this program; if not, write the Free Software Foundation,
  16. * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  17. */
  18. #include "xfs.h"
  19. #include "xfs_fs.h"
  20. #include "xfs_types.h"
  21. #include "xfs_bit.h"
  22. #include "xfs_log.h"
  23. #include "xfs_inum.h"
  24. #include "xfs_trans.h"
  25. #include "xfs_sb.h"
  26. #include "xfs_ag.h"
  27. #include "xfs_dir2.h"
  28. #include "xfs_dmapi.h"
  29. #include "xfs_mount.h"
  30. #include "xfs_bmap_btree.h"
  31. #include "xfs_alloc_btree.h"
  32. #include "xfs_ialloc_btree.h"
  33. #include "xfs_dir2_sf.h"
  34. #include "xfs_attr_sf.h"
  35. #include "xfs_dinode.h"
  36. #include "xfs_inode.h"
  37. #include "xfs_inode_item.h"
  38. #include "xfs_alloc.h"
  39. #include "xfs_btree.h"
  40. #include "xfs_btree_trace.h"
  41. #include "xfs_ialloc.h"
  42. #include "xfs_itable.h"
  43. #include "xfs_bmap.h"
  44. #include "xfs_error.h"
  45. #include "xfs_quota.h"
  46. /*
  47. * Prototypes for internal btree functions.
  48. */
  49. STATIC int xfs_bmbt_killroot(xfs_btree_cur_t *);
  50. STATIC void xfs_bmbt_log_keys(xfs_btree_cur_t *, xfs_buf_t *, int, int);
  51. STATIC void xfs_bmbt_log_ptrs(xfs_btree_cur_t *, xfs_buf_t *, int, int);
  52. STATIC int xfs_bmbt_lshift(xfs_btree_cur_t *, int, int *);
  53. STATIC int xfs_bmbt_rshift(xfs_btree_cur_t *, int, int *);
  54. STATIC int xfs_bmbt_split(xfs_btree_cur_t *, int, xfs_fsblock_t *,
  55. __uint64_t *, xfs_btree_cur_t **, int *);
  56. #undef EXIT
  57. #define ENTRY XBT_ENTRY
  58. #define ERROR XBT_ERROR
  59. #define EXIT XBT_EXIT
  60. /*
  61. * Keep the XFS_BMBT_TRACE_ names around for now until all code using them
  62. * is converted to be generic and thus switches to the XFS_BTREE_TRACE_ names.
  63. */
  64. #define XFS_BMBT_TRACE_ARGBI(c,b,i) \
  65. XFS_BTREE_TRACE_ARGBI(c,b,i)
  66. #define XFS_BMBT_TRACE_ARGBII(c,b,i,j) \
  67. XFS_BTREE_TRACE_ARGBII(c,b,i,j)
  68. #define XFS_BMBT_TRACE_ARGFFFI(c,o,b,i,j) \
  69. XFS_BTREE_TRACE_ARGFFFI(c,o,b,i,j)
  70. #define XFS_BMBT_TRACE_ARGI(c,i) \
  71. XFS_BTREE_TRACE_ARGI(c,i)
  72. #define XFS_BMBT_TRACE_ARGIFK(c,i,f,s) \
  73. XFS_BTREE_TRACE_ARGIPK(c,i,(union xfs_btree_ptr)f,s)
  74. #define XFS_BMBT_TRACE_ARGIFR(c,i,f,r) \
  75. XFS_BTREE_TRACE_ARGIPR(c,i, \
  76. (union xfs_btree_ptr)f, (union xfs_btree_rec *)r)
  77. #define XFS_BMBT_TRACE_ARGIK(c,i,k) \
  78. XFS_BTREE_TRACE_ARGIK(c,i,(union xfs_btree_key *)k)
  79. #define XFS_BMBT_TRACE_CURSOR(c,s) \
  80. XFS_BTREE_TRACE_CURSOR(c,s)
  81. /*
  82. * Internal functions.
  83. */
  84. /*
  85. * Delete record pointed to by cur/level.
  86. */
  87. STATIC int /* error */
  88. xfs_bmbt_delrec(
  89. xfs_btree_cur_t *cur,
  90. int level,
  91. int *stat) /* success/failure */
  92. {
  93. xfs_bmbt_block_t *block; /* bmap btree block */
  94. xfs_fsblock_t bno; /* fs-relative block number */
  95. xfs_buf_t *bp; /* buffer for block */
  96. int error; /* error return value */
  97. int i; /* loop counter */
  98. int j; /* temp state */
  99. xfs_bmbt_key_t key; /* bmap btree key */
  100. xfs_bmbt_key_t *kp=NULL; /* pointer to bmap btree key */
  101. xfs_fsblock_t lbno; /* left sibling block number */
  102. xfs_buf_t *lbp; /* left buffer pointer */
  103. xfs_bmbt_block_t *left; /* left btree block */
  104. xfs_bmbt_key_t *lkp; /* left btree key */
  105. xfs_bmbt_ptr_t *lpp; /* left address pointer */
  106. int lrecs=0; /* left record count */
  107. xfs_bmbt_rec_t *lrp; /* left record pointer */
  108. xfs_mount_t *mp; /* file system mount point */
  109. xfs_bmbt_ptr_t *pp; /* pointer to bmap block addr */
  110. int ptr; /* key/record index */
  111. xfs_fsblock_t rbno; /* right sibling block number */
  112. xfs_buf_t *rbp; /* right buffer pointer */
  113. xfs_bmbt_block_t *right; /* right btree block */
  114. xfs_bmbt_key_t *rkp; /* right btree key */
  115. xfs_bmbt_rec_t *rp; /* pointer to bmap btree rec */
  116. xfs_bmbt_ptr_t *rpp; /* right address pointer */
  117. xfs_bmbt_block_t *rrblock; /* right-right btree block */
  118. xfs_buf_t *rrbp; /* right-right buffer pointer */
  119. int rrecs=0; /* right record count */
  120. xfs_bmbt_rec_t *rrp; /* right record pointer */
  121. xfs_btree_cur_t *tcur; /* temporary btree cursor */
  122. int numrecs; /* temporary numrec count */
  123. int numlrecs, numrrecs;
  124. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  125. XFS_BMBT_TRACE_ARGI(cur, level);
  126. ptr = cur->bc_ptrs[level];
  127. tcur = NULL;
  128. if (ptr == 0) {
  129. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  130. *stat = 0;
  131. return 0;
  132. }
  133. block = xfs_bmbt_get_block(cur, level, &bp);
  134. numrecs = be16_to_cpu(block->bb_numrecs);
  135. #ifdef DEBUG
  136. if ((error = xfs_btree_check_lblock(cur, block, level, bp))) {
  137. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  138. goto error0;
  139. }
  140. #endif
  141. if (ptr > numrecs) {
  142. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  143. *stat = 0;
  144. return 0;
  145. }
  146. XFS_STATS_INC(xs_bmbt_delrec);
  147. if (level > 0) {
  148. kp = XFS_BMAP_KEY_IADDR(block, 1, cur);
  149. pp = XFS_BMAP_PTR_IADDR(block, 1, cur);
  150. #ifdef DEBUG
  151. for (i = ptr; i < numrecs; i++) {
  152. if ((error = xfs_btree_check_lptr_disk(cur, pp[i], level))) {
  153. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  154. goto error0;
  155. }
  156. }
  157. #endif
  158. if (ptr < numrecs) {
  159. memmove(&kp[ptr - 1], &kp[ptr],
  160. (numrecs - ptr) * sizeof(*kp));
  161. memmove(&pp[ptr - 1], &pp[ptr],
  162. (numrecs - ptr) * sizeof(*pp));
  163. xfs_bmbt_log_ptrs(cur, bp, ptr, numrecs - 1);
  164. xfs_bmbt_log_keys(cur, bp, ptr, numrecs - 1);
  165. }
  166. } else {
  167. rp = XFS_BMAP_REC_IADDR(block, 1, cur);
  168. if (ptr < numrecs) {
  169. memmove(&rp[ptr - 1], &rp[ptr],
  170. (numrecs - ptr) * sizeof(*rp));
  171. xfs_bmbt_log_recs(cur, bp, ptr, numrecs - 1);
  172. }
  173. if (ptr == 1) {
  174. key.br_startoff =
  175. cpu_to_be64(xfs_bmbt_disk_get_startoff(rp));
  176. kp = &key;
  177. }
  178. }
  179. numrecs--;
  180. block->bb_numrecs = cpu_to_be16(numrecs);
  181. xfs_bmbt_log_block(cur, bp, XFS_BB_NUMRECS);
  182. /*
  183. * We're at the root level.
  184. * First, shrink the root block in-memory.
  185. * Try to get rid of the next level down.
  186. * If we can't then there's nothing left to do.
  187. */
  188. if (level == cur->bc_nlevels - 1) {
  189. xfs_iroot_realloc(cur->bc_private.b.ip, -1,
  190. cur->bc_private.b.whichfork);
  191. if ((error = xfs_bmbt_killroot(cur))) {
  192. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  193. goto error0;
  194. }
  195. if (level > 0 && (error = xfs_btree_decrement(cur, level, &j))) {
  196. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  197. goto error0;
  198. }
  199. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  200. *stat = 1;
  201. return 0;
  202. }
  203. if (ptr == 1 && (error = xfs_btree_updkey(cur, (union xfs_btree_key *)kp, level + 1))) {
  204. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  205. goto error0;
  206. }
  207. if (numrecs >= XFS_BMAP_BLOCK_IMINRECS(level, cur)) {
  208. if (level > 0 && (error = xfs_btree_decrement(cur, level, &j))) {
  209. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  210. goto error0;
  211. }
  212. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  213. *stat = 1;
  214. return 0;
  215. }
  216. rbno = be64_to_cpu(block->bb_rightsib);
  217. lbno = be64_to_cpu(block->bb_leftsib);
  218. /*
  219. * One child of root, need to get a chance to copy its contents
  220. * into the root and delete it. Can't go up to next level,
  221. * there's nothing to delete there.
  222. */
  223. if (lbno == NULLFSBLOCK && rbno == NULLFSBLOCK &&
  224. level == cur->bc_nlevels - 2) {
  225. if ((error = xfs_bmbt_killroot(cur))) {
  226. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  227. goto error0;
  228. }
  229. if (level > 0 && (error = xfs_btree_decrement(cur, level, &i))) {
  230. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  231. goto error0;
  232. }
  233. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  234. *stat = 1;
  235. return 0;
  236. }
  237. ASSERT(rbno != NULLFSBLOCK || lbno != NULLFSBLOCK);
  238. if ((error = xfs_btree_dup_cursor(cur, &tcur))) {
  239. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  240. goto error0;
  241. }
  242. bno = NULLFSBLOCK;
  243. if (rbno != NULLFSBLOCK) {
  244. i = xfs_btree_lastrec(tcur, level);
  245. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  246. if ((error = xfs_btree_increment(tcur, level, &i))) {
  247. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  248. goto error0;
  249. }
  250. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  251. i = xfs_btree_lastrec(tcur, level);
  252. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  253. rbp = tcur->bc_bufs[level];
  254. right = XFS_BUF_TO_BMBT_BLOCK(rbp);
  255. #ifdef DEBUG
  256. if ((error = xfs_btree_check_lblock(cur, right, level, rbp))) {
  257. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  258. goto error0;
  259. }
  260. #endif
  261. bno = be64_to_cpu(right->bb_leftsib);
  262. if (be16_to_cpu(right->bb_numrecs) - 1 >=
  263. XFS_BMAP_BLOCK_IMINRECS(level, cur)) {
  264. if ((error = xfs_bmbt_lshift(tcur, level, &i))) {
  265. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  266. goto error0;
  267. }
  268. if (i) {
  269. ASSERT(be16_to_cpu(block->bb_numrecs) >=
  270. XFS_BMAP_BLOCK_IMINRECS(level, tcur));
  271. xfs_btree_del_cursor(tcur, XFS_BTREE_NOERROR);
  272. tcur = NULL;
  273. if (level > 0) {
  274. if ((error = xfs_btree_decrement(cur,
  275. level, &i))) {
  276. XFS_BMBT_TRACE_CURSOR(cur,
  277. ERROR);
  278. goto error0;
  279. }
  280. }
  281. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  282. *stat = 1;
  283. return 0;
  284. }
  285. }
  286. rrecs = be16_to_cpu(right->bb_numrecs);
  287. if (lbno != NULLFSBLOCK) {
  288. i = xfs_btree_firstrec(tcur, level);
  289. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  290. if ((error = xfs_btree_decrement(tcur, level, &i))) {
  291. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  292. goto error0;
  293. }
  294. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  295. }
  296. }
  297. if (lbno != NULLFSBLOCK) {
  298. i = xfs_btree_firstrec(tcur, level);
  299. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  300. /*
  301. * decrement to last in block
  302. */
  303. if ((error = xfs_btree_decrement(tcur, level, &i))) {
  304. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  305. goto error0;
  306. }
  307. i = xfs_btree_firstrec(tcur, level);
  308. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  309. lbp = tcur->bc_bufs[level];
  310. left = XFS_BUF_TO_BMBT_BLOCK(lbp);
  311. #ifdef DEBUG
  312. if ((error = xfs_btree_check_lblock(cur, left, level, lbp))) {
  313. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  314. goto error0;
  315. }
  316. #endif
  317. bno = be64_to_cpu(left->bb_rightsib);
  318. if (be16_to_cpu(left->bb_numrecs) - 1 >=
  319. XFS_BMAP_BLOCK_IMINRECS(level, cur)) {
  320. if ((error = xfs_bmbt_rshift(tcur, level, &i))) {
  321. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  322. goto error0;
  323. }
  324. if (i) {
  325. ASSERT(be16_to_cpu(block->bb_numrecs) >=
  326. XFS_BMAP_BLOCK_IMINRECS(level, tcur));
  327. xfs_btree_del_cursor(tcur, XFS_BTREE_NOERROR);
  328. tcur = NULL;
  329. if (level == 0)
  330. cur->bc_ptrs[0]++;
  331. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  332. *stat = 1;
  333. return 0;
  334. }
  335. }
  336. lrecs = be16_to_cpu(left->bb_numrecs);
  337. }
  338. xfs_btree_del_cursor(tcur, XFS_BTREE_NOERROR);
  339. tcur = NULL;
  340. mp = cur->bc_mp;
  341. ASSERT(bno != NULLFSBLOCK);
  342. if (lbno != NULLFSBLOCK &&
  343. lrecs + be16_to_cpu(block->bb_numrecs) <= XFS_BMAP_BLOCK_IMAXRECS(level, cur)) {
  344. rbno = bno;
  345. right = block;
  346. rbp = bp;
  347. if ((error = xfs_btree_read_bufl(mp, cur->bc_tp, lbno, 0, &lbp,
  348. XFS_BMAP_BTREE_REF))) {
  349. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  350. goto error0;
  351. }
  352. left = XFS_BUF_TO_BMBT_BLOCK(lbp);
  353. if ((error = xfs_btree_check_lblock(cur, left, level, lbp))) {
  354. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  355. goto error0;
  356. }
  357. } else if (rbno != NULLFSBLOCK &&
  358. rrecs + be16_to_cpu(block->bb_numrecs) <=
  359. XFS_BMAP_BLOCK_IMAXRECS(level, cur)) {
  360. lbno = bno;
  361. left = block;
  362. lbp = bp;
  363. if ((error = xfs_btree_read_bufl(mp, cur->bc_tp, rbno, 0, &rbp,
  364. XFS_BMAP_BTREE_REF))) {
  365. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  366. goto error0;
  367. }
  368. right = XFS_BUF_TO_BMBT_BLOCK(rbp);
  369. if ((error = xfs_btree_check_lblock(cur, right, level, rbp))) {
  370. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  371. goto error0;
  372. }
  373. lrecs = be16_to_cpu(left->bb_numrecs);
  374. } else {
  375. if (level > 0 && (error = xfs_btree_decrement(cur, level, &i))) {
  376. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  377. goto error0;
  378. }
  379. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  380. *stat = 1;
  381. return 0;
  382. }
  383. numlrecs = be16_to_cpu(left->bb_numrecs);
  384. numrrecs = be16_to_cpu(right->bb_numrecs);
  385. if (level > 0) {
  386. lkp = XFS_BMAP_KEY_IADDR(left, numlrecs + 1, cur);
  387. lpp = XFS_BMAP_PTR_IADDR(left, numlrecs + 1, cur);
  388. rkp = XFS_BMAP_KEY_IADDR(right, 1, cur);
  389. rpp = XFS_BMAP_PTR_IADDR(right, 1, cur);
  390. #ifdef DEBUG
  391. for (i = 0; i < numrrecs; i++) {
  392. if ((error = xfs_btree_check_lptr_disk(cur, rpp[i], level))) {
  393. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  394. goto error0;
  395. }
  396. }
  397. #endif
  398. memcpy(lkp, rkp, numrrecs * sizeof(*lkp));
  399. memcpy(lpp, rpp, numrrecs * sizeof(*lpp));
  400. xfs_bmbt_log_keys(cur, lbp, numlrecs + 1, numlrecs + numrrecs);
  401. xfs_bmbt_log_ptrs(cur, lbp, numlrecs + 1, numlrecs + numrrecs);
  402. } else {
  403. lrp = XFS_BMAP_REC_IADDR(left, numlrecs + 1, cur);
  404. rrp = XFS_BMAP_REC_IADDR(right, 1, cur);
  405. memcpy(lrp, rrp, numrrecs * sizeof(*lrp));
  406. xfs_bmbt_log_recs(cur, lbp, numlrecs + 1, numlrecs + numrrecs);
  407. }
  408. be16_add_cpu(&left->bb_numrecs, numrrecs);
  409. left->bb_rightsib = right->bb_rightsib;
  410. xfs_bmbt_log_block(cur, lbp, XFS_BB_RIGHTSIB | XFS_BB_NUMRECS);
  411. if (be64_to_cpu(left->bb_rightsib) != NULLDFSBNO) {
  412. if ((error = xfs_btree_read_bufl(mp, cur->bc_tp,
  413. be64_to_cpu(left->bb_rightsib),
  414. 0, &rrbp, XFS_BMAP_BTREE_REF))) {
  415. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  416. goto error0;
  417. }
  418. rrblock = XFS_BUF_TO_BMBT_BLOCK(rrbp);
  419. if ((error = xfs_btree_check_lblock(cur, rrblock, level, rrbp))) {
  420. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  421. goto error0;
  422. }
  423. rrblock->bb_leftsib = cpu_to_be64(lbno);
  424. xfs_bmbt_log_block(cur, rrbp, XFS_BB_LEFTSIB);
  425. }
  426. xfs_bmap_add_free(XFS_DADDR_TO_FSB(mp, XFS_BUF_ADDR(rbp)), 1,
  427. cur->bc_private.b.flist, mp);
  428. cur->bc_private.b.ip->i_d.di_nblocks--;
  429. xfs_trans_log_inode(cur->bc_tp, cur->bc_private.b.ip, XFS_ILOG_CORE);
  430. XFS_TRANS_MOD_DQUOT_BYINO(mp, cur->bc_tp, cur->bc_private.b.ip,
  431. XFS_TRANS_DQ_BCOUNT, -1L);
  432. xfs_trans_binval(cur->bc_tp, rbp);
  433. if (bp != lbp) {
  434. cur->bc_bufs[level] = lbp;
  435. cur->bc_ptrs[level] += lrecs;
  436. cur->bc_ra[level] = 0;
  437. } else if ((error = xfs_btree_increment(cur, level + 1, &i))) {
  438. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  439. goto error0;
  440. }
  441. if (level > 0)
  442. cur->bc_ptrs[level]--;
  443. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  444. *stat = 2;
  445. return 0;
  446. error0:
  447. if (tcur)
  448. xfs_btree_del_cursor(tcur, XFS_BTREE_ERROR);
  449. return error;
  450. }
  451. /*
  452. * Insert one record/level. Return information to the caller
  453. * allowing the next level up to proceed if necessary.
  454. */
  455. STATIC int /* error */
  456. xfs_bmbt_insrec(
  457. xfs_btree_cur_t *cur,
  458. int level,
  459. xfs_fsblock_t *bnop,
  460. xfs_bmbt_rec_t *recp,
  461. xfs_btree_cur_t **curp,
  462. int *stat) /* no-go/done/continue */
  463. {
  464. xfs_bmbt_block_t *block; /* bmap btree block */
  465. xfs_buf_t *bp; /* buffer for block */
  466. int error; /* error return value */
  467. int i; /* loop index */
  468. xfs_bmbt_key_t key; /* bmap btree key */
  469. xfs_bmbt_key_t *kp=NULL; /* pointer to bmap btree key */
  470. int logflags; /* inode logging flags */
  471. xfs_fsblock_t nbno; /* new block number */
  472. struct xfs_btree_cur *ncur; /* new btree cursor */
  473. __uint64_t startoff; /* new btree key value */
  474. xfs_bmbt_rec_t nrec; /* new record count */
  475. int optr; /* old key/record index */
  476. xfs_bmbt_ptr_t *pp; /* pointer to bmap block addr */
  477. int ptr; /* key/record index */
  478. xfs_bmbt_rec_t *rp=NULL; /* pointer to bmap btree rec */
  479. int numrecs;
  480. ASSERT(level < cur->bc_nlevels);
  481. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  482. XFS_BMBT_TRACE_ARGIFR(cur, level, *bnop, recp);
  483. ncur = NULL;
  484. key.br_startoff = cpu_to_be64(xfs_bmbt_disk_get_startoff(recp));
  485. optr = ptr = cur->bc_ptrs[level];
  486. if (ptr == 0) {
  487. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  488. *stat = 0;
  489. return 0;
  490. }
  491. XFS_STATS_INC(xs_bmbt_insrec);
  492. block = xfs_bmbt_get_block(cur, level, &bp);
  493. numrecs = be16_to_cpu(block->bb_numrecs);
  494. #ifdef DEBUG
  495. if ((error = xfs_btree_check_lblock(cur, block, level, bp))) {
  496. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  497. return error;
  498. }
  499. if (ptr <= numrecs) {
  500. if (level == 0) {
  501. rp = XFS_BMAP_REC_IADDR(block, ptr, cur);
  502. xfs_btree_check_rec(XFS_BTNUM_BMAP, recp, rp);
  503. } else {
  504. kp = XFS_BMAP_KEY_IADDR(block, ptr, cur);
  505. xfs_btree_check_key(XFS_BTNUM_BMAP, &key, kp);
  506. }
  507. }
  508. #endif
  509. nbno = NULLFSBLOCK;
  510. if (numrecs == XFS_BMAP_BLOCK_IMAXRECS(level, cur)) {
  511. if (numrecs < XFS_BMAP_BLOCK_DMAXRECS(level, cur)) {
  512. /*
  513. * A root block, that can be made bigger.
  514. */
  515. xfs_iroot_realloc(cur->bc_private.b.ip, 1,
  516. cur->bc_private.b.whichfork);
  517. block = xfs_bmbt_get_block(cur, level, &bp);
  518. } else if (level == cur->bc_nlevels - 1) {
  519. if ((error = xfs_bmbt_newroot(cur, &logflags, stat)) ||
  520. *stat == 0) {
  521. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  522. return error;
  523. }
  524. xfs_trans_log_inode(cur->bc_tp, cur->bc_private.b.ip,
  525. logflags);
  526. block = xfs_bmbt_get_block(cur, level, &bp);
  527. } else {
  528. if ((error = xfs_bmbt_rshift(cur, level, &i))) {
  529. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  530. return error;
  531. }
  532. if (i) {
  533. /* nothing */
  534. } else {
  535. if ((error = xfs_bmbt_lshift(cur, level, &i))) {
  536. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  537. return error;
  538. }
  539. if (i) {
  540. optr = ptr = cur->bc_ptrs[level];
  541. } else {
  542. if ((error = xfs_bmbt_split(cur, level,
  543. &nbno, &startoff, &ncur,
  544. &i))) {
  545. XFS_BMBT_TRACE_CURSOR(cur,
  546. ERROR);
  547. return error;
  548. }
  549. if (i) {
  550. block = xfs_bmbt_get_block(
  551. cur, level, &bp);
  552. #ifdef DEBUG
  553. if ((error =
  554. xfs_btree_check_lblock(cur,
  555. block, level, bp))) {
  556. XFS_BMBT_TRACE_CURSOR(
  557. cur, ERROR);
  558. return error;
  559. }
  560. #endif
  561. ptr = cur->bc_ptrs[level];
  562. xfs_bmbt_disk_set_allf(&nrec,
  563. startoff, 0, 0,
  564. XFS_EXT_NORM);
  565. } else {
  566. XFS_BMBT_TRACE_CURSOR(cur,
  567. EXIT);
  568. *stat = 0;
  569. return 0;
  570. }
  571. }
  572. }
  573. }
  574. }
  575. numrecs = be16_to_cpu(block->bb_numrecs);
  576. if (level > 0) {
  577. kp = XFS_BMAP_KEY_IADDR(block, 1, cur);
  578. pp = XFS_BMAP_PTR_IADDR(block, 1, cur);
  579. #ifdef DEBUG
  580. for (i = numrecs; i >= ptr; i--) {
  581. if ((error = xfs_btree_check_lptr_disk(cur, pp[i - 1],
  582. level))) {
  583. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  584. return error;
  585. }
  586. }
  587. #endif
  588. memmove(&kp[ptr], &kp[ptr - 1],
  589. (numrecs - ptr + 1) * sizeof(*kp));
  590. memmove(&pp[ptr], &pp[ptr - 1],
  591. (numrecs - ptr + 1) * sizeof(*pp));
  592. #ifdef DEBUG
  593. if ((error = xfs_btree_check_lptr(cur, *bnop, level))) {
  594. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  595. return error;
  596. }
  597. #endif
  598. kp[ptr - 1] = key;
  599. pp[ptr - 1] = cpu_to_be64(*bnop);
  600. numrecs++;
  601. block->bb_numrecs = cpu_to_be16(numrecs);
  602. xfs_bmbt_log_keys(cur, bp, ptr, numrecs);
  603. xfs_bmbt_log_ptrs(cur, bp, ptr, numrecs);
  604. } else {
  605. rp = XFS_BMAP_REC_IADDR(block, 1, cur);
  606. memmove(&rp[ptr], &rp[ptr - 1],
  607. (numrecs - ptr + 1) * sizeof(*rp));
  608. rp[ptr - 1] = *recp;
  609. numrecs++;
  610. block->bb_numrecs = cpu_to_be16(numrecs);
  611. xfs_bmbt_log_recs(cur, bp, ptr, numrecs);
  612. }
  613. xfs_bmbt_log_block(cur, bp, XFS_BB_NUMRECS);
  614. #ifdef DEBUG
  615. if (ptr < numrecs) {
  616. if (level == 0)
  617. xfs_btree_check_rec(XFS_BTNUM_BMAP, rp + ptr - 1,
  618. rp + ptr);
  619. else
  620. xfs_btree_check_key(XFS_BTNUM_BMAP, kp + ptr - 1,
  621. kp + ptr);
  622. }
  623. #endif
  624. if (optr == 1 && (error = xfs_btree_updkey(cur, (union xfs_btree_key *)&key, level + 1))) {
  625. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  626. return error;
  627. }
  628. *bnop = nbno;
  629. if (nbno != NULLFSBLOCK) {
  630. *recp = nrec;
  631. *curp = ncur;
  632. }
  633. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  634. *stat = 1;
  635. return 0;
  636. }
  637. STATIC int
  638. xfs_bmbt_killroot(
  639. xfs_btree_cur_t *cur)
  640. {
  641. xfs_bmbt_block_t *block;
  642. xfs_bmbt_block_t *cblock;
  643. xfs_buf_t *cbp;
  644. xfs_bmbt_key_t *ckp;
  645. xfs_bmbt_ptr_t *cpp;
  646. #ifdef DEBUG
  647. int error;
  648. #endif
  649. int i;
  650. xfs_bmbt_key_t *kp;
  651. xfs_inode_t *ip;
  652. xfs_ifork_t *ifp;
  653. int level;
  654. xfs_bmbt_ptr_t *pp;
  655. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  656. level = cur->bc_nlevels - 1;
  657. ASSERT(level >= 1);
  658. /*
  659. * Don't deal with the root block needs to be a leaf case.
  660. * We're just going to turn the thing back into extents anyway.
  661. */
  662. if (level == 1) {
  663. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  664. return 0;
  665. }
  666. block = xfs_bmbt_get_block(cur, level, &cbp);
  667. /*
  668. * Give up if the root has multiple children.
  669. */
  670. if (be16_to_cpu(block->bb_numrecs) != 1) {
  671. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  672. return 0;
  673. }
  674. /*
  675. * Only do this if the next level will fit.
  676. * Then the data must be copied up to the inode,
  677. * instead of freeing the root you free the next level.
  678. */
  679. cbp = cur->bc_bufs[level - 1];
  680. cblock = XFS_BUF_TO_BMBT_BLOCK(cbp);
  681. if (be16_to_cpu(cblock->bb_numrecs) > XFS_BMAP_BLOCK_DMAXRECS(level, cur)) {
  682. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  683. return 0;
  684. }
  685. ASSERT(be64_to_cpu(cblock->bb_leftsib) == NULLDFSBNO);
  686. ASSERT(be64_to_cpu(cblock->bb_rightsib) == NULLDFSBNO);
  687. ip = cur->bc_private.b.ip;
  688. ifp = XFS_IFORK_PTR(ip, cur->bc_private.b.whichfork);
  689. ASSERT(XFS_BMAP_BLOCK_IMAXRECS(level, cur) ==
  690. XFS_BMAP_BROOT_MAXRECS(ifp->if_broot_bytes));
  691. i = (int)(be16_to_cpu(cblock->bb_numrecs) - XFS_BMAP_BLOCK_IMAXRECS(level, cur));
  692. if (i) {
  693. xfs_iroot_realloc(ip, i, cur->bc_private.b.whichfork);
  694. block = ifp->if_broot;
  695. }
  696. be16_add_cpu(&block->bb_numrecs, i);
  697. ASSERT(block->bb_numrecs == cblock->bb_numrecs);
  698. kp = XFS_BMAP_KEY_IADDR(block, 1, cur);
  699. ckp = XFS_BMAP_KEY_IADDR(cblock, 1, cur);
  700. memcpy(kp, ckp, be16_to_cpu(block->bb_numrecs) * sizeof(*kp));
  701. pp = XFS_BMAP_PTR_IADDR(block, 1, cur);
  702. cpp = XFS_BMAP_PTR_IADDR(cblock, 1, cur);
  703. #ifdef DEBUG
  704. for (i = 0; i < be16_to_cpu(cblock->bb_numrecs); i++) {
  705. if ((error = xfs_btree_check_lptr_disk(cur, cpp[i], level - 1))) {
  706. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  707. return error;
  708. }
  709. }
  710. #endif
  711. memcpy(pp, cpp, be16_to_cpu(block->bb_numrecs) * sizeof(*pp));
  712. xfs_bmap_add_free(XFS_DADDR_TO_FSB(cur->bc_mp, XFS_BUF_ADDR(cbp)), 1,
  713. cur->bc_private.b.flist, cur->bc_mp);
  714. ip->i_d.di_nblocks--;
  715. XFS_TRANS_MOD_DQUOT_BYINO(cur->bc_mp, cur->bc_tp, ip,
  716. XFS_TRANS_DQ_BCOUNT, -1L);
  717. xfs_trans_binval(cur->bc_tp, cbp);
  718. cur->bc_bufs[level - 1] = NULL;
  719. be16_add_cpu(&block->bb_level, -1);
  720. xfs_trans_log_inode(cur->bc_tp, ip,
  721. XFS_ILOG_CORE | XFS_ILOG_FBROOT(cur->bc_private.b.whichfork));
  722. cur->bc_nlevels--;
  723. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  724. return 0;
  725. }
  726. /*
  727. * Log key values from the btree block.
  728. */
  729. STATIC void
  730. xfs_bmbt_log_keys(
  731. xfs_btree_cur_t *cur,
  732. xfs_buf_t *bp,
  733. int kfirst,
  734. int klast)
  735. {
  736. xfs_trans_t *tp;
  737. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  738. XFS_BMBT_TRACE_ARGBII(cur, bp, kfirst, klast);
  739. tp = cur->bc_tp;
  740. if (bp) {
  741. xfs_bmbt_block_t *block;
  742. int first;
  743. xfs_bmbt_key_t *kp;
  744. int last;
  745. block = XFS_BUF_TO_BMBT_BLOCK(bp);
  746. kp = XFS_BMAP_KEY_DADDR(block, 1, cur);
  747. first = (int)((xfs_caddr_t)&kp[kfirst - 1] - (xfs_caddr_t)block);
  748. last = (int)(((xfs_caddr_t)&kp[klast] - 1) - (xfs_caddr_t)block);
  749. xfs_trans_log_buf(tp, bp, first, last);
  750. } else {
  751. xfs_inode_t *ip;
  752. ip = cur->bc_private.b.ip;
  753. xfs_trans_log_inode(tp, ip,
  754. XFS_ILOG_FBROOT(cur->bc_private.b.whichfork));
  755. }
  756. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  757. }
  758. /*
  759. * Log pointer values from the btree block.
  760. */
  761. STATIC void
  762. xfs_bmbt_log_ptrs(
  763. xfs_btree_cur_t *cur,
  764. xfs_buf_t *bp,
  765. int pfirst,
  766. int plast)
  767. {
  768. xfs_trans_t *tp;
  769. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  770. XFS_BMBT_TRACE_ARGBII(cur, bp, pfirst, plast);
  771. tp = cur->bc_tp;
  772. if (bp) {
  773. xfs_bmbt_block_t *block;
  774. int first;
  775. int last;
  776. xfs_bmbt_ptr_t *pp;
  777. block = XFS_BUF_TO_BMBT_BLOCK(bp);
  778. pp = XFS_BMAP_PTR_DADDR(block, 1, cur);
  779. first = (int)((xfs_caddr_t)&pp[pfirst - 1] - (xfs_caddr_t)block);
  780. last = (int)(((xfs_caddr_t)&pp[plast] - 1) - (xfs_caddr_t)block);
  781. xfs_trans_log_buf(tp, bp, first, last);
  782. } else {
  783. xfs_inode_t *ip;
  784. ip = cur->bc_private.b.ip;
  785. xfs_trans_log_inode(tp, ip,
  786. XFS_ILOG_FBROOT(cur->bc_private.b.whichfork));
  787. }
  788. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  789. }
  790. /*
  791. * Move 1 record left from cur/level if possible.
  792. * Update cur to reflect the new path.
  793. */
  794. STATIC int /* error */
  795. xfs_bmbt_lshift(
  796. xfs_btree_cur_t *cur,
  797. int level,
  798. int *stat) /* success/failure */
  799. {
  800. int error; /* error return value */
  801. #ifdef DEBUG
  802. int i; /* loop counter */
  803. #endif
  804. xfs_bmbt_key_t key; /* bmap btree key */
  805. xfs_buf_t *lbp; /* left buffer pointer */
  806. xfs_bmbt_block_t *left; /* left btree block */
  807. xfs_bmbt_key_t *lkp=NULL; /* left btree key */
  808. xfs_bmbt_ptr_t *lpp; /* left address pointer */
  809. int lrecs; /* left record count */
  810. xfs_bmbt_rec_t *lrp=NULL; /* left record pointer */
  811. xfs_mount_t *mp; /* file system mount point */
  812. xfs_buf_t *rbp; /* right buffer pointer */
  813. xfs_bmbt_block_t *right; /* right btree block */
  814. xfs_bmbt_key_t *rkp=NULL; /* right btree key */
  815. xfs_bmbt_ptr_t *rpp=NULL; /* right address pointer */
  816. xfs_bmbt_rec_t *rrp=NULL; /* right record pointer */
  817. int rrecs; /* right record count */
  818. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  819. XFS_BMBT_TRACE_ARGI(cur, level);
  820. if (level == cur->bc_nlevels - 1) {
  821. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  822. *stat = 0;
  823. return 0;
  824. }
  825. rbp = cur->bc_bufs[level];
  826. right = XFS_BUF_TO_BMBT_BLOCK(rbp);
  827. #ifdef DEBUG
  828. if ((error = xfs_btree_check_lblock(cur, right, level, rbp))) {
  829. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  830. return error;
  831. }
  832. #endif
  833. if (be64_to_cpu(right->bb_leftsib) == NULLDFSBNO) {
  834. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  835. *stat = 0;
  836. return 0;
  837. }
  838. if (cur->bc_ptrs[level] <= 1) {
  839. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  840. *stat = 0;
  841. return 0;
  842. }
  843. mp = cur->bc_mp;
  844. if ((error = xfs_btree_read_bufl(mp, cur->bc_tp, be64_to_cpu(right->bb_leftsib), 0,
  845. &lbp, XFS_BMAP_BTREE_REF))) {
  846. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  847. return error;
  848. }
  849. left = XFS_BUF_TO_BMBT_BLOCK(lbp);
  850. if ((error = xfs_btree_check_lblock(cur, left, level, lbp))) {
  851. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  852. return error;
  853. }
  854. if (be16_to_cpu(left->bb_numrecs) == XFS_BMAP_BLOCK_IMAXRECS(level, cur)) {
  855. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  856. *stat = 0;
  857. return 0;
  858. }
  859. lrecs = be16_to_cpu(left->bb_numrecs) + 1;
  860. if (level > 0) {
  861. lkp = XFS_BMAP_KEY_IADDR(left, lrecs, cur);
  862. rkp = XFS_BMAP_KEY_IADDR(right, 1, cur);
  863. *lkp = *rkp;
  864. xfs_bmbt_log_keys(cur, lbp, lrecs, lrecs);
  865. lpp = XFS_BMAP_PTR_IADDR(left, lrecs, cur);
  866. rpp = XFS_BMAP_PTR_IADDR(right, 1, cur);
  867. #ifdef DEBUG
  868. if ((error = xfs_btree_check_lptr_disk(cur, *rpp, level))) {
  869. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  870. return error;
  871. }
  872. #endif
  873. *lpp = *rpp;
  874. xfs_bmbt_log_ptrs(cur, lbp, lrecs, lrecs);
  875. } else {
  876. lrp = XFS_BMAP_REC_IADDR(left, lrecs, cur);
  877. rrp = XFS_BMAP_REC_IADDR(right, 1, cur);
  878. *lrp = *rrp;
  879. xfs_bmbt_log_recs(cur, lbp, lrecs, lrecs);
  880. }
  881. left->bb_numrecs = cpu_to_be16(lrecs);
  882. xfs_bmbt_log_block(cur, lbp, XFS_BB_NUMRECS);
  883. #ifdef DEBUG
  884. if (level > 0)
  885. xfs_btree_check_key(XFS_BTNUM_BMAP, lkp - 1, lkp);
  886. else
  887. xfs_btree_check_rec(XFS_BTNUM_BMAP, lrp - 1, lrp);
  888. #endif
  889. rrecs = be16_to_cpu(right->bb_numrecs) - 1;
  890. right->bb_numrecs = cpu_to_be16(rrecs);
  891. xfs_bmbt_log_block(cur, rbp, XFS_BB_NUMRECS);
  892. if (level > 0) {
  893. #ifdef DEBUG
  894. for (i = 0; i < rrecs; i++) {
  895. if ((error = xfs_btree_check_lptr_disk(cur, rpp[i + 1],
  896. level))) {
  897. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  898. return error;
  899. }
  900. }
  901. #endif
  902. memmove(rkp, rkp + 1, rrecs * sizeof(*rkp));
  903. memmove(rpp, rpp + 1, rrecs * sizeof(*rpp));
  904. xfs_bmbt_log_keys(cur, rbp, 1, rrecs);
  905. xfs_bmbt_log_ptrs(cur, rbp, 1, rrecs);
  906. } else {
  907. memmove(rrp, rrp + 1, rrecs * sizeof(*rrp));
  908. xfs_bmbt_log_recs(cur, rbp, 1, rrecs);
  909. key.br_startoff = cpu_to_be64(xfs_bmbt_disk_get_startoff(rrp));
  910. rkp = &key;
  911. }
  912. if ((error = xfs_btree_updkey(cur, (union xfs_btree_key *)rkp, level + 1))) {
  913. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  914. return error;
  915. }
  916. cur->bc_ptrs[level]--;
  917. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  918. *stat = 1;
  919. return 0;
  920. }
  921. /*
  922. * Move 1 record right from cur/level if possible.
  923. * Update cur to reflect the new path.
  924. */
  925. STATIC int /* error */
  926. xfs_bmbt_rshift(
  927. xfs_btree_cur_t *cur,
  928. int level,
  929. int *stat) /* success/failure */
  930. {
  931. int error; /* error return value */
  932. int i; /* loop counter */
  933. xfs_bmbt_key_t key; /* bmap btree key */
  934. xfs_buf_t *lbp; /* left buffer pointer */
  935. xfs_bmbt_block_t *left; /* left btree block */
  936. xfs_bmbt_key_t *lkp; /* left btree key */
  937. xfs_bmbt_ptr_t *lpp; /* left address pointer */
  938. xfs_bmbt_rec_t *lrp; /* left record pointer */
  939. xfs_mount_t *mp; /* file system mount point */
  940. xfs_buf_t *rbp; /* right buffer pointer */
  941. xfs_bmbt_block_t *right; /* right btree block */
  942. xfs_bmbt_key_t *rkp; /* right btree key */
  943. xfs_bmbt_ptr_t *rpp; /* right address pointer */
  944. xfs_bmbt_rec_t *rrp=NULL; /* right record pointer */
  945. struct xfs_btree_cur *tcur; /* temporary btree cursor */
  946. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  947. XFS_BMBT_TRACE_ARGI(cur, level);
  948. if (level == cur->bc_nlevels - 1) {
  949. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  950. *stat = 0;
  951. return 0;
  952. }
  953. lbp = cur->bc_bufs[level];
  954. left = XFS_BUF_TO_BMBT_BLOCK(lbp);
  955. #ifdef DEBUG
  956. if ((error = xfs_btree_check_lblock(cur, left, level, lbp))) {
  957. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  958. return error;
  959. }
  960. #endif
  961. if (be64_to_cpu(left->bb_rightsib) == NULLDFSBNO) {
  962. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  963. *stat = 0;
  964. return 0;
  965. }
  966. if (cur->bc_ptrs[level] >= be16_to_cpu(left->bb_numrecs)) {
  967. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  968. *stat = 0;
  969. return 0;
  970. }
  971. mp = cur->bc_mp;
  972. if ((error = xfs_btree_read_bufl(mp, cur->bc_tp, be64_to_cpu(left->bb_rightsib), 0,
  973. &rbp, XFS_BMAP_BTREE_REF))) {
  974. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  975. return error;
  976. }
  977. right = XFS_BUF_TO_BMBT_BLOCK(rbp);
  978. if ((error = xfs_btree_check_lblock(cur, right, level, rbp))) {
  979. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  980. return error;
  981. }
  982. if (be16_to_cpu(right->bb_numrecs) == XFS_BMAP_BLOCK_IMAXRECS(level, cur)) {
  983. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  984. *stat = 0;
  985. return 0;
  986. }
  987. if (level > 0) {
  988. lkp = XFS_BMAP_KEY_IADDR(left, be16_to_cpu(left->bb_numrecs), cur);
  989. lpp = XFS_BMAP_PTR_IADDR(left, be16_to_cpu(left->bb_numrecs), cur);
  990. rkp = XFS_BMAP_KEY_IADDR(right, 1, cur);
  991. rpp = XFS_BMAP_PTR_IADDR(right, 1, cur);
  992. #ifdef DEBUG
  993. for (i = be16_to_cpu(right->bb_numrecs) - 1; i >= 0; i--) {
  994. if ((error = xfs_btree_check_lptr_disk(cur, rpp[i], level))) {
  995. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  996. return error;
  997. }
  998. }
  999. #endif
  1000. memmove(rkp + 1, rkp, be16_to_cpu(right->bb_numrecs) * sizeof(*rkp));
  1001. memmove(rpp + 1, rpp, be16_to_cpu(right->bb_numrecs) * sizeof(*rpp));
  1002. #ifdef DEBUG
  1003. if ((error = xfs_btree_check_lptr_disk(cur, *lpp, level))) {
  1004. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1005. return error;
  1006. }
  1007. #endif
  1008. *rkp = *lkp;
  1009. *rpp = *lpp;
  1010. xfs_bmbt_log_keys(cur, rbp, 1, be16_to_cpu(right->bb_numrecs) + 1);
  1011. xfs_bmbt_log_ptrs(cur, rbp, 1, be16_to_cpu(right->bb_numrecs) + 1);
  1012. } else {
  1013. lrp = XFS_BMAP_REC_IADDR(left, be16_to_cpu(left->bb_numrecs), cur);
  1014. rrp = XFS_BMAP_REC_IADDR(right, 1, cur);
  1015. memmove(rrp + 1, rrp, be16_to_cpu(right->bb_numrecs) * sizeof(*rrp));
  1016. *rrp = *lrp;
  1017. xfs_bmbt_log_recs(cur, rbp, 1, be16_to_cpu(right->bb_numrecs) + 1);
  1018. key.br_startoff = cpu_to_be64(xfs_bmbt_disk_get_startoff(rrp));
  1019. rkp = &key;
  1020. }
  1021. be16_add_cpu(&left->bb_numrecs, -1);
  1022. xfs_bmbt_log_block(cur, lbp, XFS_BB_NUMRECS);
  1023. be16_add_cpu(&right->bb_numrecs, 1);
  1024. #ifdef DEBUG
  1025. if (level > 0)
  1026. xfs_btree_check_key(XFS_BTNUM_BMAP, rkp, rkp + 1);
  1027. else
  1028. xfs_btree_check_rec(XFS_BTNUM_BMAP, rrp, rrp + 1);
  1029. #endif
  1030. xfs_bmbt_log_block(cur, rbp, XFS_BB_NUMRECS);
  1031. if ((error = xfs_btree_dup_cursor(cur, &tcur))) {
  1032. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1033. return error;
  1034. }
  1035. i = xfs_btree_lastrec(tcur, level);
  1036. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  1037. if ((error = xfs_btree_increment(tcur, level, &i))) {
  1038. XFS_BMBT_TRACE_CURSOR(tcur, ERROR);
  1039. goto error1;
  1040. }
  1041. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  1042. if ((error = xfs_btree_updkey(tcur, (union xfs_btree_key *)rkp, level + 1))) {
  1043. XFS_BMBT_TRACE_CURSOR(tcur, ERROR);
  1044. goto error1;
  1045. }
  1046. xfs_btree_del_cursor(tcur, XFS_BTREE_NOERROR);
  1047. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1048. *stat = 1;
  1049. return 0;
  1050. error0:
  1051. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1052. error1:
  1053. xfs_btree_del_cursor(tcur, XFS_BTREE_ERROR);
  1054. return error;
  1055. }
  1056. /*
  1057. * Determine the extent state.
  1058. */
  1059. /* ARGSUSED */
  1060. STATIC xfs_exntst_t
  1061. xfs_extent_state(
  1062. xfs_filblks_t blks,
  1063. int extent_flag)
  1064. {
  1065. if (extent_flag) {
  1066. ASSERT(blks != 0); /* saved for DMIG */
  1067. return XFS_EXT_UNWRITTEN;
  1068. }
  1069. return XFS_EXT_NORM;
  1070. }
  1071. /*
  1072. * Split cur/level block in half.
  1073. * Return new block number and its first record (to be inserted into parent).
  1074. */
  1075. STATIC int /* error */
  1076. xfs_bmbt_split(
  1077. xfs_btree_cur_t *cur,
  1078. int level,
  1079. xfs_fsblock_t *bnop,
  1080. __uint64_t *startoff,
  1081. xfs_btree_cur_t **curp,
  1082. int *stat) /* success/failure */
  1083. {
  1084. xfs_alloc_arg_t args; /* block allocation args */
  1085. int error; /* error return value */
  1086. int i; /* loop counter */
  1087. xfs_fsblock_t lbno; /* left sibling block number */
  1088. xfs_buf_t *lbp; /* left buffer pointer */
  1089. xfs_bmbt_block_t *left; /* left btree block */
  1090. xfs_bmbt_key_t *lkp; /* left btree key */
  1091. xfs_bmbt_ptr_t *lpp; /* left address pointer */
  1092. xfs_bmbt_rec_t *lrp; /* left record pointer */
  1093. xfs_buf_t *rbp; /* right buffer pointer */
  1094. xfs_bmbt_block_t *right; /* right btree block */
  1095. xfs_bmbt_key_t *rkp; /* right btree key */
  1096. xfs_bmbt_ptr_t *rpp; /* right address pointer */
  1097. xfs_bmbt_block_t *rrblock; /* right-right btree block */
  1098. xfs_buf_t *rrbp; /* right-right buffer pointer */
  1099. xfs_bmbt_rec_t *rrp; /* right record pointer */
  1100. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1101. // disable until merged into common code
  1102. // XFS_BMBT_TRACE_ARGIFK(cur, level, *bnop, *startoff);
  1103. args.tp = cur->bc_tp;
  1104. args.mp = cur->bc_mp;
  1105. lbp = cur->bc_bufs[level];
  1106. lbno = XFS_DADDR_TO_FSB(args.mp, XFS_BUF_ADDR(lbp));
  1107. left = XFS_BUF_TO_BMBT_BLOCK(lbp);
  1108. args.fsbno = cur->bc_private.b.firstblock;
  1109. args.firstblock = args.fsbno;
  1110. args.minleft = 0;
  1111. if (args.fsbno == NULLFSBLOCK) {
  1112. args.fsbno = lbno;
  1113. args.type = XFS_ALLOCTYPE_START_BNO;
  1114. /*
  1115. * Make sure there is sufficient room left in the AG to
  1116. * complete a full tree split for an extent insert. If
  1117. * we are converting the middle part of an extent then
  1118. * we may need space for two tree splits.
  1119. *
  1120. * We are relying on the caller to make the correct block
  1121. * reservation for this operation to succeed. If the
  1122. * reservation amount is insufficient then we may fail a
  1123. * block allocation here and corrupt the filesystem.
  1124. */
  1125. args.minleft = xfs_trans_get_block_res(args.tp);
  1126. } else if (cur->bc_private.b.flist->xbf_low)
  1127. args.type = XFS_ALLOCTYPE_START_BNO;
  1128. else
  1129. args.type = XFS_ALLOCTYPE_NEAR_BNO;
  1130. args.mod = args.alignment = args.total = args.isfl =
  1131. args.userdata = args.minalignslop = 0;
  1132. args.minlen = args.maxlen = args.prod = 1;
  1133. args.wasdel = cur->bc_private.b.flags & XFS_BTCUR_BPRV_WASDEL;
  1134. if (!args.wasdel && xfs_trans_get_block_res(args.tp) == 0) {
  1135. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1136. return XFS_ERROR(ENOSPC);
  1137. }
  1138. if ((error = xfs_alloc_vextent(&args))) {
  1139. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1140. return error;
  1141. }
  1142. if (args.fsbno == NULLFSBLOCK && args.minleft) {
  1143. /*
  1144. * Could not find an AG with enough free space to satisfy
  1145. * a full btree split. Try again without minleft and if
  1146. * successful activate the lowspace algorithm.
  1147. */
  1148. args.fsbno = 0;
  1149. args.type = XFS_ALLOCTYPE_FIRST_AG;
  1150. args.minleft = 0;
  1151. if ((error = xfs_alloc_vextent(&args))) {
  1152. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1153. return error;
  1154. }
  1155. cur->bc_private.b.flist->xbf_low = 1;
  1156. }
  1157. if (args.fsbno == NULLFSBLOCK) {
  1158. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1159. *stat = 0;
  1160. return 0;
  1161. }
  1162. ASSERT(args.len == 1);
  1163. cur->bc_private.b.firstblock = args.fsbno;
  1164. cur->bc_private.b.allocated++;
  1165. cur->bc_private.b.ip->i_d.di_nblocks++;
  1166. xfs_trans_log_inode(args.tp, cur->bc_private.b.ip, XFS_ILOG_CORE);
  1167. XFS_TRANS_MOD_DQUOT_BYINO(args.mp, args.tp, cur->bc_private.b.ip,
  1168. XFS_TRANS_DQ_BCOUNT, 1L);
  1169. rbp = xfs_btree_get_bufl(args.mp, args.tp, args.fsbno, 0);
  1170. right = XFS_BUF_TO_BMBT_BLOCK(rbp);
  1171. #ifdef DEBUG
  1172. if ((error = xfs_btree_check_lblock(cur, left, level, rbp))) {
  1173. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1174. return error;
  1175. }
  1176. #endif
  1177. right->bb_magic = cpu_to_be32(XFS_BMAP_MAGIC);
  1178. right->bb_level = left->bb_level;
  1179. right->bb_numrecs = cpu_to_be16(be16_to_cpu(left->bb_numrecs) / 2);
  1180. if ((be16_to_cpu(left->bb_numrecs) & 1) &&
  1181. cur->bc_ptrs[level] <= be16_to_cpu(right->bb_numrecs) + 1)
  1182. be16_add_cpu(&right->bb_numrecs, 1);
  1183. i = be16_to_cpu(left->bb_numrecs) - be16_to_cpu(right->bb_numrecs) + 1;
  1184. if (level > 0) {
  1185. lkp = XFS_BMAP_KEY_IADDR(left, i, cur);
  1186. lpp = XFS_BMAP_PTR_IADDR(left, i, cur);
  1187. rkp = XFS_BMAP_KEY_IADDR(right, 1, cur);
  1188. rpp = XFS_BMAP_PTR_IADDR(right, 1, cur);
  1189. #ifdef DEBUG
  1190. for (i = 0; i < be16_to_cpu(right->bb_numrecs); i++) {
  1191. if ((error = xfs_btree_check_lptr_disk(cur, lpp[i], level))) {
  1192. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1193. return error;
  1194. }
  1195. }
  1196. #endif
  1197. memcpy(rkp, lkp, be16_to_cpu(right->bb_numrecs) * sizeof(*rkp));
  1198. memcpy(rpp, lpp, be16_to_cpu(right->bb_numrecs) * sizeof(*rpp));
  1199. xfs_bmbt_log_keys(cur, rbp, 1, be16_to_cpu(right->bb_numrecs));
  1200. xfs_bmbt_log_ptrs(cur, rbp, 1, be16_to_cpu(right->bb_numrecs));
  1201. *startoff = be64_to_cpu(rkp->br_startoff);
  1202. } else {
  1203. lrp = XFS_BMAP_REC_IADDR(left, i, cur);
  1204. rrp = XFS_BMAP_REC_IADDR(right, 1, cur);
  1205. memcpy(rrp, lrp, be16_to_cpu(right->bb_numrecs) * sizeof(*rrp));
  1206. xfs_bmbt_log_recs(cur, rbp, 1, be16_to_cpu(right->bb_numrecs));
  1207. *startoff = xfs_bmbt_disk_get_startoff(rrp);
  1208. }
  1209. be16_add_cpu(&left->bb_numrecs, -(be16_to_cpu(right->bb_numrecs)));
  1210. right->bb_rightsib = left->bb_rightsib;
  1211. left->bb_rightsib = cpu_to_be64(args.fsbno);
  1212. right->bb_leftsib = cpu_to_be64(lbno);
  1213. xfs_bmbt_log_block(cur, rbp, XFS_BB_ALL_BITS);
  1214. xfs_bmbt_log_block(cur, lbp, XFS_BB_NUMRECS | XFS_BB_RIGHTSIB);
  1215. if (be64_to_cpu(right->bb_rightsib) != NULLDFSBNO) {
  1216. if ((error = xfs_btree_read_bufl(args.mp, args.tp,
  1217. be64_to_cpu(right->bb_rightsib), 0, &rrbp,
  1218. XFS_BMAP_BTREE_REF))) {
  1219. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1220. return error;
  1221. }
  1222. rrblock = XFS_BUF_TO_BMBT_BLOCK(rrbp);
  1223. if ((error = xfs_btree_check_lblock(cur, rrblock, level, rrbp))) {
  1224. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1225. return error;
  1226. }
  1227. rrblock->bb_leftsib = cpu_to_be64(args.fsbno);
  1228. xfs_bmbt_log_block(cur, rrbp, XFS_BB_LEFTSIB);
  1229. }
  1230. if (cur->bc_ptrs[level] > be16_to_cpu(left->bb_numrecs) + 1) {
  1231. xfs_btree_setbuf(cur, level, rbp);
  1232. cur->bc_ptrs[level] -= be16_to_cpu(left->bb_numrecs);
  1233. }
  1234. if (level + 1 < cur->bc_nlevels) {
  1235. if ((error = xfs_btree_dup_cursor(cur, curp))) {
  1236. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1237. return error;
  1238. }
  1239. (*curp)->bc_ptrs[level + 1]++;
  1240. }
  1241. *bnop = args.fsbno;
  1242. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1243. *stat = 1;
  1244. return 0;
  1245. }
  1246. /*
  1247. * Convert on-disk form of btree root to in-memory form.
  1248. */
  1249. void
  1250. xfs_bmdr_to_bmbt(
  1251. xfs_bmdr_block_t *dblock,
  1252. int dblocklen,
  1253. xfs_bmbt_block_t *rblock,
  1254. int rblocklen)
  1255. {
  1256. int dmxr;
  1257. xfs_bmbt_key_t *fkp;
  1258. __be64 *fpp;
  1259. xfs_bmbt_key_t *tkp;
  1260. __be64 *tpp;
  1261. rblock->bb_magic = cpu_to_be32(XFS_BMAP_MAGIC);
  1262. rblock->bb_level = dblock->bb_level;
  1263. ASSERT(be16_to_cpu(rblock->bb_level) > 0);
  1264. rblock->bb_numrecs = dblock->bb_numrecs;
  1265. rblock->bb_leftsib = cpu_to_be64(NULLDFSBNO);
  1266. rblock->bb_rightsib = cpu_to_be64(NULLDFSBNO);
  1267. dmxr = (int)XFS_BTREE_BLOCK_MAXRECS(dblocklen, xfs_bmdr, 0);
  1268. fkp = XFS_BTREE_KEY_ADDR(xfs_bmdr, dblock, 1);
  1269. tkp = XFS_BMAP_BROOT_KEY_ADDR(rblock, 1, rblocklen);
  1270. fpp = XFS_BTREE_PTR_ADDR(xfs_bmdr, dblock, 1, dmxr);
  1271. tpp = XFS_BMAP_BROOT_PTR_ADDR(rblock, 1, rblocklen);
  1272. dmxr = be16_to_cpu(dblock->bb_numrecs);
  1273. memcpy(tkp, fkp, sizeof(*fkp) * dmxr);
  1274. memcpy(tpp, fpp, sizeof(*fpp) * dmxr);
  1275. }
  1276. /*
  1277. * Delete the record pointed to by cur.
  1278. */
  1279. int /* error */
  1280. xfs_bmbt_delete(
  1281. xfs_btree_cur_t *cur,
  1282. int *stat) /* success/failure */
  1283. {
  1284. int error; /* error return value */
  1285. int i;
  1286. int level;
  1287. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1288. for (level = 0, i = 2; i == 2; level++) {
  1289. if ((error = xfs_bmbt_delrec(cur, level, &i))) {
  1290. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1291. return error;
  1292. }
  1293. }
  1294. if (i == 0) {
  1295. for (level = 1; level < cur->bc_nlevels; level++) {
  1296. if (cur->bc_ptrs[level] == 0) {
  1297. if ((error = xfs_btree_decrement(cur, level,
  1298. &i))) {
  1299. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1300. return error;
  1301. }
  1302. break;
  1303. }
  1304. }
  1305. }
  1306. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1307. *stat = i;
  1308. return 0;
  1309. }
  1310. /*
  1311. * Convert a compressed bmap extent record to an uncompressed form.
  1312. * This code must be in sync with the routines xfs_bmbt_get_startoff,
  1313. * xfs_bmbt_get_startblock, xfs_bmbt_get_blockcount and xfs_bmbt_get_state.
  1314. */
  1315. STATIC_INLINE void
  1316. __xfs_bmbt_get_all(
  1317. __uint64_t l0,
  1318. __uint64_t l1,
  1319. xfs_bmbt_irec_t *s)
  1320. {
  1321. int ext_flag;
  1322. xfs_exntst_t st;
  1323. ext_flag = (int)(l0 >> (64 - BMBT_EXNTFLAG_BITLEN));
  1324. s->br_startoff = ((xfs_fileoff_t)l0 &
  1325. XFS_MASK64LO(64 - BMBT_EXNTFLAG_BITLEN)) >> 9;
  1326. #if XFS_BIG_BLKNOS
  1327. s->br_startblock = (((xfs_fsblock_t)l0 & XFS_MASK64LO(9)) << 43) |
  1328. (((xfs_fsblock_t)l1) >> 21);
  1329. #else
  1330. #ifdef DEBUG
  1331. {
  1332. xfs_dfsbno_t b;
  1333. b = (((xfs_dfsbno_t)l0 & XFS_MASK64LO(9)) << 43) |
  1334. (((xfs_dfsbno_t)l1) >> 21);
  1335. ASSERT((b >> 32) == 0 || ISNULLDSTARTBLOCK(b));
  1336. s->br_startblock = (xfs_fsblock_t)b;
  1337. }
  1338. #else /* !DEBUG */
  1339. s->br_startblock = (xfs_fsblock_t)(((xfs_dfsbno_t)l1) >> 21);
  1340. #endif /* DEBUG */
  1341. #endif /* XFS_BIG_BLKNOS */
  1342. s->br_blockcount = (xfs_filblks_t)(l1 & XFS_MASK64LO(21));
  1343. /* This is xfs_extent_state() in-line */
  1344. if (ext_flag) {
  1345. ASSERT(s->br_blockcount != 0); /* saved for DMIG */
  1346. st = XFS_EXT_UNWRITTEN;
  1347. } else
  1348. st = XFS_EXT_NORM;
  1349. s->br_state = st;
  1350. }
  1351. void
  1352. xfs_bmbt_get_all(
  1353. xfs_bmbt_rec_host_t *r,
  1354. xfs_bmbt_irec_t *s)
  1355. {
  1356. __xfs_bmbt_get_all(r->l0, r->l1, s);
  1357. }
  1358. /*
  1359. * Get the block pointer for the given level of the cursor.
  1360. * Fill in the buffer pointer, if applicable.
  1361. */
  1362. xfs_bmbt_block_t *
  1363. xfs_bmbt_get_block(
  1364. xfs_btree_cur_t *cur,
  1365. int level,
  1366. xfs_buf_t **bpp)
  1367. {
  1368. xfs_ifork_t *ifp;
  1369. xfs_bmbt_block_t *rval;
  1370. if (level < cur->bc_nlevels - 1) {
  1371. *bpp = cur->bc_bufs[level];
  1372. rval = XFS_BUF_TO_BMBT_BLOCK(*bpp);
  1373. } else {
  1374. *bpp = NULL;
  1375. ifp = XFS_IFORK_PTR(cur->bc_private.b.ip,
  1376. cur->bc_private.b.whichfork);
  1377. rval = ifp->if_broot;
  1378. }
  1379. return rval;
  1380. }
  1381. /*
  1382. * Extract the blockcount field from an in memory bmap extent record.
  1383. */
  1384. xfs_filblks_t
  1385. xfs_bmbt_get_blockcount(
  1386. xfs_bmbt_rec_host_t *r)
  1387. {
  1388. return (xfs_filblks_t)(r->l1 & XFS_MASK64LO(21));
  1389. }
  1390. /*
  1391. * Extract the startblock field from an in memory bmap extent record.
  1392. */
  1393. xfs_fsblock_t
  1394. xfs_bmbt_get_startblock(
  1395. xfs_bmbt_rec_host_t *r)
  1396. {
  1397. #if XFS_BIG_BLKNOS
  1398. return (((xfs_fsblock_t)r->l0 & XFS_MASK64LO(9)) << 43) |
  1399. (((xfs_fsblock_t)r->l1) >> 21);
  1400. #else
  1401. #ifdef DEBUG
  1402. xfs_dfsbno_t b;
  1403. b = (((xfs_dfsbno_t)r->l0 & XFS_MASK64LO(9)) << 43) |
  1404. (((xfs_dfsbno_t)r->l1) >> 21);
  1405. ASSERT((b >> 32) == 0 || ISNULLDSTARTBLOCK(b));
  1406. return (xfs_fsblock_t)b;
  1407. #else /* !DEBUG */
  1408. return (xfs_fsblock_t)(((xfs_dfsbno_t)r->l1) >> 21);
  1409. #endif /* DEBUG */
  1410. #endif /* XFS_BIG_BLKNOS */
  1411. }
  1412. /*
  1413. * Extract the startoff field from an in memory bmap extent record.
  1414. */
  1415. xfs_fileoff_t
  1416. xfs_bmbt_get_startoff(
  1417. xfs_bmbt_rec_host_t *r)
  1418. {
  1419. return ((xfs_fileoff_t)r->l0 &
  1420. XFS_MASK64LO(64 - BMBT_EXNTFLAG_BITLEN)) >> 9;
  1421. }
  1422. xfs_exntst_t
  1423. xfs_bmbt_get_state(
  1424. xfs_bmbt_rec_host_t *r)
  1425. {
  1426. int ext_flag;
  1427. ext_flag = (int)((r->l0) >> (64 - BMBT_EXNTFLAG_BITLEN));
  1428. return xfs_extent_state(xfs_bmbt_get_blockcount(r),
  1429. ext_flag);
  1430. }
  1431. /* Endian flipping versions of the bmbt extraction functions */
  1432. void
  1433. xfs_bmbt_disk_get_all(
  1434. xfs_bmbt_rec_t *r,
  1435. xfs_bmbt_irec_t *s)
  1436. {
  1437. __xfs_bmbt_get_all(be64_to_cpu(r->l0), be64_to_cpu(r->l1), s);
  1438. }
  1439. /*
  1440. * Extract the blockcount field from an on disk bmap extent record.
  1441. */
  1442. xfs_filblks_t
  1443. xfs_bmbt_disk_get_blockcount(
  1444. xfs_bmbt_rec_t *r)
  1445. {
  1446. return (xfs_filblks_t)(be64_to_cpu(r->l1) & XFS_MASK64LO(21));
  1447. }
  1448. /*
  1449. * Extract the startoff field from a disk format bmap extent record.
  1450. */
  1451. xfs_fileoff_t
  1452. xfs_bmbt_disk_get_startoff(
  1453. xfs_bmbt_rec_t *r)
  1454. {
  1455. return ((xfs_fileoff_t)be64_to_cpu(r->l0) &
  1456. XFS_MASK64LO(64 - BMBT_EXNTFLAG_BITLEN)) >> 9;
  1457. }
  1458. /*
  1459. * Insert the current record at the point referenced by cur.
  1460. *
  1461. * A multi-level split of the tree on insert will invalidate the original
  1462. * cursor. All callers of this function should assume that the cursor is
  1463. * no longer valid and revalidate it.
  1464. */
  1465. int /* error */
  1466. xfs_bmbt_insert(
  1467. xfs_btree_cur_t *cur,
  1468. int *stat) /* success/failure */
  1469. {
  1470. int error; /* error return value */
  1471. int i;
  1472. int level;
  1473. xfs_fsblock_t nbno;
  1474. xfs_btree_cur_t *ncur;
  1475. xfs_bmbt_rec_t nrec;
  1476. xfs_btree_cur_t *pcur;
  1477. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1478. level = 0;
  1479. nbno = NULLFSBLOCK;
  1480. xfs_bmbt_disk_set_all(&nrec, &cur->bc_rec.b);
  1481. ncur = NULL;
  1482. pcur = cur;
  1483. do {
  1484. if ((error = xfs_bmbt_insrec(pcur, level++, &nbno, &nrec, &ncur,
  1485. &i))) {
  1486. if (pcur != cur)
  1487. xfs_btree_del_cursor(pcur, XFS_BTREE_ERROR);
  1488. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1489. return error;
  1490. }
  1491. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  1492. if (pcur != cur && (ncur || nbno == NULLFSBLOCK)) {
  1493. cur->bc_nlevels = pcur->bc_nlevels;
  1494. cur->bc_private.b.allocated +=
  1495. pcur->bc_private.b.allocated;
  1496. pcur->bc_private.b.allocated = 0;
  1497. ASSERT((cur->bc_private.b.firstblock != NULLFSBLOCK) ||
  1498. XFS_IS_REALTIME_INODE(cur->bc_private.b.ip));
  1499. cur->bc_private.b.firstblock =
  1500. pcur->bc_private.b.firstblock;
  1501. ASSERT(cur->bc_private.b.flist ==
  1502. pcur->bc_private.b.flist);
  1503. xfs_btree_del_cursor(pcur, XFS_BTREE_NOERROR);
  1504. }
  1505. if (ncur) {
  1506. pcur = ncur;
  1507. ncur = NULL;
  1508. }
  1509. } while (nbno != NULLFSBLOCK);
  1510. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1511. *stat = i;
  1512. return 0;
  1513. error0:
  1514. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1515. return error;
  1516. }
  1517. /*
  1518. * Log fields from the btree block header.
  1519. */
  1520. void
  1521. xfs_bmbt_log_block(
  1522. xfs_btree_cur_t *cur,
  1523. xfs_buf_t *bp,
  1524. int fields)
  1525. {
  1526. int first;
  1527. int last;
  1528. xfs_trans_t *tp;
  1529. static const short offsets[] = {
  1530. offsetof(xfs_bmbt_block_t, bb_magic),
  1531. offsetof(xfs_bmbt_block_t, bb_level),
  1532. offsetof(xfs_bmbt_block_t, bb_numrecs),
  1533. offsetof(xfs_bmbt_block_t, bb_leftsib),
  1534. offsetof(xfs_bmbt_block_t, bb_rightsib),
  1535. sizeof(xfs_bmbt_block_t)
  1536. };
  1537. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1538. XFS_BMBT_TRACE_ARGBI(cur, bp, fields);
  1539. tp = cur->bc_tp;
  1540. if (bp) {
  1541. xfs_btree_offsets(fields, offsets, XFS_BB_NUM_BITS, &first,
  1542. &last);
  1543. xfs_trans_log_buf(tp, bp, first, last);
  1544. } else
  1545. xfs_trans_log_inode(tp, cur->bc_private.b.ip,
  1546. XFS_ILOG_FBROOT(cur->bc_private.b.whichfork));
  1547. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1548. }
  1549. /*
  1550. * Log record values from the btree block.
  1551. */
  1552. void
  1553. xfs_bmbt_log_recs(
  1554. xfs_btree_cur_t *cur,
  1555. xfs_buf_t *bp,
  1556. int rfirst,
  1557. int rlast)
  1558. {
  1559. xfs_bmbt_block_t *block;
  1560. int first;
  1561. int last;
  1562. xfs_bmbt_rec_t *rp;
  1563. xfs_trans_t *tp;
  1564. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1565. XFS_BMBT_TRACE_ARGBII(cur, bp, rfirst, rlast);
  1566. ASSERT(bp);
  1567. tp = cur->bc_tp;
  1568. block = XFS_BUF_TO_BMBT_BLOCK(bp);
  1569. rp = XFS_BMAP_REC_DADDR(block, 1, cur);
  1570. first = (int)((xfs_caddr_t)&rp[rfirst - 1] - (xfs_caddr_t)block);
  1571. last = (int)(((xfs_caddr_t)&rp[rlast] - 1) - (xfs_caddr_t)block);
  1572. xfs_trans_log_buf(tp, bp, first, last);
  1573. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1574. }
  1575. /*
  1576. * Give the bmap btree a new root block. Copy the old broot contents
  1577. * down into a real block and make the broot point to it.
  1578. */
  1579. int /* error */
  1580. xfs_bmbt_newroot(
  1581. xfs_btree_cur_t *cur, /* btree cursor */
  1582. int *logflags, /* logging flags for inode */
  1583. int *stat) /* return status - 0 fail */
  1584. {
  1585. xfs_alloc_arg_t args; /* allocation arguments */
  1586. xfs_bmbt_block_t *block; /* bmap btree block */
  1587. xfs_buf_t *bp; /* buffer for block */
  1588. xfs_bmbt_block_t *cblock; /* child btree block */
  1589. xfs_bmbt_key_t *ckp; /* child key pointer */
  1590. xfs_bmbt_ptr_t *cpp; /* child ptr pointer */
  1591. int error; /* error return code */
  1592. #ifdef DEBUG
  1593. int i; /* loop counter */
  1594. #endif
  1595. xfs_bmbt_key_t *kp; /* pointer to bmap btree key */
  1596. int level; /* btree level */
  1597. xfs_bmbt_ptr_t *pp; /* pointer to bmap block addr */
  1598. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1599. level = cur->bc_nlevels - 1;
  1600. block = xfs_bmbt_get_block(cur, level, &bp);
  1601. /*
  1602. * Copy the root into a real block.
  1603. */
  1604. args.mp = cur->bc_mp;
  1605. pp = XFS_BMAP_PTR_IADDR(block, 1, cur);
  1606. args.tp = cur->bc_tp;
  1607. args.fsbno = cur->bc_private.b.firstblock;
  1608. args.mod = args.minleft = args.alignment = args.total = args.isfl =
  1609. args.userdata = args.minalignslop = 0;
  1610. args.minlen = args.maxlen = args.prod = 1;
  1611. args.wasdel = cur->bc_private.b.flags & XFS_BTCUR_BPRV_WASDEL;
  1612. args.firstblock = args.fsbno;
  1613. if (args.fsbno == NULLFSBLOCK) {
  1614. #ifdef DEBUG
  1615. if ((error = xfs_btree_check_lptr_disk(cur, *pp, level))) {
  1616. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1617. return error;
  1618. }
  1619. #endif
  1620. args.fsbno = be64_to_cpu(*pp);
  1621. args.type = XFS_ALLOCTYPE_START_BNO;
  1622. } else if (cur->bc_private.b.flist->xbf_low)
  1623. args.type = XFS_ALLOCTYPE_START_BNO;
  1624. else
  1625. args.type = XFS_ALLOCTYPE_NEAR_BNO;
  1626. if ((error = xfs_alloc_vextent(&args))) {
  1627. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1628. return error;
  1629. }
  1630. if (args.fsbno == NULLFSBLOCK) {
  1631. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1632. *stat = 0;
  1633. return 0;
  1634. }
  1635. ASSERT(args.len == 1);
  1636. cur->bc_private.b.firstblock = args.fsbno;
  1637. cur->bc_private.b.allocated++;
  1638. cur->bc_private.b.ip->i_d.di_nblocks++;
  1639. XFS_TRANS_MOD_DQUOT_BYINO(args.mp, args.tp, cur->bc_private.b.ip,
  1640. XFS_TRANS_DQ_BCOUNT, 1L);
  1641. bp = xfs_btree_get_bufl(args.mp, cur->bc_tp, args.fsbno, 0);
  1642. cblock = XFS_BUF_TO_BMBT_BLOCK(bp);
  1643. *cblock = *block;
  1644. be16_add_cpu(&block->bb_level, 1);
  1645. block->bb_numrecs = cpu_to_be16(1);
  1646. cur->bc_nlevels++;
  1647. cur->bc_ptrs[level + 1] = 1;
  1648. kp = XFS_BMAP_KEY_IADDR(block, 1, cur);
  1649. ckp = XFS_BMAP_KEY_IADDR(cblock, 1, cur);
  1650. memcpy(ckp, kp, be16_to_cpu(cblock->bb_numrecs) * sizeof(*kp));
  1651. cpp = XFS_BMAP_PTR_IADDR(cblock, 1, cur);
  1652. #ifdef DEBUG
  1653. for (i = 0; i < be16_to_cpu(cblock->bb_numrecs); i++) {
  1654. if ((error = xfs_btree_check_lptr_disk(cur, pp[i], level))) {
  1655. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1656. return error;
  1657. }
  1658. }
  1659. #endif
  1660. memcpy(cpp, pp, be16_to_cpu(cblock->bb_numrecs) * sizeof(*pp));
  1661. #ifdef DEBUG
  1662. if ((error = xfs_btree_check_lptr(cur, args.fsbno, level))) {
  1663. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1664. return error;
  1665. }
  1666. #endif
  1667. *pp = cpu_to_be64(args.fsbno);
  1668. xfs_iroot_realloc(cur->bc_private.b.ip, 1 - be16_to_cpu(cblock->bb_numrecs),
  1669. cur->bc_private.b.whichfork);
  1670. xfs_btree_setbuf(cur, level, bp);
  1671. /*
  1672. * Do all this logging at the end so that
  1673. * the root is at the right level.
  1674. */
  1675. xfs_bmbt_log_block(cur, bp, XFS_BB_ALL_BITS);
  1676. xfs_bmbt_log_keys(cur, bp, 1, be16_to_cpu(cblock->bb_numrecs));
  1677. xfs_bmbt_log_ptrs(cur, bp, 1, be16_to_cpu(cblock->bb_numrecs));
  1678. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1679. *logflags |=
  1680. XFS_ILOG_CORE | XFS_ILOG_FBROOT(cur->bc_private.b.whichfork);
  1681. *stat = 1;
  1682. return 0;
  1683. }
  1684. /*
  1685. * Set all the fields in a bmap extent record from the arguments.
  1686. */
  1687. void
  1688. xfs_bmbt_set_allf(
  1689. xfs_bmbt_rec_host_t *r,
  1690. xfs_fileoff_t startoff,
  1691. xfs_fsblock_t startblock,
  1692. xfs_filblks_t blockcount,
  1693. xfs_exntst_t state)
  1694. {
  1695. int extent_flag = (state == XFS_EXT_NORM) ? 0 : 1;
  1696. ASSERT(state == XFS_EXT_NORM || state == XFS_EXT_UNWRITTEN);
  1697. ASSERT((startoff & XFS_MASK64HI(64-BMBT_STARTOFF_BITLEN)) == 0);
  1698. ASSERT((blockcount & XFS_MASK64HI(64-BMBT_BLOCKCOUNT_BITLEN)) == 0);
  1699. #if XFS_BIG_BLKNOS
  1700. ASSERT((startblock & XFS_MASK64HI(64-BMBT_STARTBLOCK_BITLEN)) == 0);
  1701. r->l0 = ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  1702. ((xfs_bmbt_rec_base_t)startoff << 9) |
  1703. ((xfs_bmbt_rec_base_t)startblock >> 43);
  1704. r->l1 = ((xfs_bmbt_rec_base_t)startblock << 21) |
  1705. ((xfs_bmbt_rec_base_t)blockcount &
  1706. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  1707. #else /* !XFS_BIG_BLKNOS */
  1708. if (ISNULLSTARTBLOCK(startblock)) {
  1709. r->l0 = ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  1710. ((xfs_bmbt_rec_base_t)startoff << 9) |
  1711. (xfs_bmbt_rec_base_t)XFS_MASK64LO(9);
  1712. r->l1 = XFS_MASK64HI(11) |
  1713. ((xfs_bmbt_rec_base_t)startblock << 21) |
  1714. ((xfs_bmbt_rec_base_t)blockcount &
  1715. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  1716. } else {
  1717. r->l0 = ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  1718. ((xfs_bmbt_rec_base_t)startoff << 9);
  1719. r->l1 = ((xfs_bmbt_rec_base_t)startblock << 21) |
  1720. ((xfs_bmbt_rec_base_t)blockcount &
  1721. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  1722. }
  1723. #endif /* XFS_BIG_BLKNOS */
  1724. }
  1725. /*
  1726. * Set all the fields in a bmap extent record from the uncompressed form.
  1727. */
  1728. void
  1729. xfs_bmbt_set_all(
  1730. xfs_bmbt_rec_host_t *r,
  1731. xfs_bmbt_irec_t *s)
  1732. {
  1733. xfs_bmbt_set_allf(r, s->br_startoff, s->br_startblock,
  1734. s->br_blockcount, s->br_state);
  1735. }
  1736. /*
  1737. * Set all the fields in a disk format bmap extent record from the arguments.
  1738. */
  1739. void
  1740. xfs_bmbt_disk_set_allf(
  1741. xfs_bmbt_rec_t *r,
  1742. xfs_fileoff_t startoff,
  1743. xfs_fsblock_t startblock,
  1744. xfs_filblks_t blockcount,
  1745. xfs_exntst_t state)
  1746. {
  1747. int extent_flag = (state == XFS_EXT_NORM) ? 0 : 1;
  1748. ASSERT(state == XFS_EXT_NORM || state == XFS_EXT_UNWRITTEN);
  1749. ASSERT((startoff & XFS_MASK64HI(64-BMBT_STARTOFF_BITLEN)) == 0);
  1750. ASSERT((blockcount & XFS_MASK64HI(64-BMBT_BLOCKCOUNT_BITLEN)) == 0);
  1751. #if XFS_BIG_BLKNOS
  1752. ASSERT((startblock & XFS_MASK64HI(64-BMBT_STARTBLOCK_BITLEN)) == 0);
  1753. r->l0 = cpu_to_be64(
  1754. ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  1755. ((xfs_bmbt_rec_base_t)startoff << 9) |
  1756. ((xfs_bmbt_rec_base_t)startblock >> 43));
  1757. r->l1 = cpu_to_be64(
  1758. ((xfs_bmbt_rec_base_t)startblock << 21) |
  1759. ((xfs_bmbt_rec_base_t)blockcount &
  1760. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21)));
  1761. #else /* !XFS_BIG_BLKNOS */
  1762. if (ISNULLSTARTBLOCK(startblock)) {
  1763. r->l0 = cpu_to_be64(
  1764. ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  1765. ((xfs_bmbt_rec_base_t)startoff << 9) |
  1766. (xfs_bmbt_rec_base_t)XFS_MASK64LO(9));
  1767. r->l1 = cpu_to_be64(XFS_MASK64HI(11) |
  1768. ((xfs_bmbt_rec_base_t)startblock << 21) |
  1769. ((xfs_bmbt_rec_base_t)blockcount &
  1770. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21)));
  1771. } else {
  1772. r->l0 = cpu_to_be64(
  1773. ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  1774. ((xfs_bmbt_rec_base_t)startoff << 9));
  1775. r->l1 = cpu_to_be64(
  1776. ((xfs_bmbt_rec_base_t)startblock << 21) |
  1777. ((xfs_bmbt_rec_base_t)blockcount &
  1778. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21)));
  1779. }
  1780. #endif /* XFS_BIG_BLKNOS */
  1781. }
  1782. /*
  1783. * Set all the fields in a bmap extent record from the uncompressed form.
  1784. */
  1785. void
  1786. xfs_bmbt_disk_set_all(
  1787. xfs_bmbt_rec_t *r,
  1788. xfs_bmbt_irec_t *s)
  1789. {
  1790. xfs_bmbt_disk_set_allf(r, s->br_startoff, s->br_startblock,
  1791. s->br_blockcount, s->br_state);
  1792. }
  1793. /*
  1794. * Set the blockcount field in a bmap extent record.
  1795. */
  1796. void
  1797. xfs_bmbt_set_blockcount(
  1798. xfs_bmbt_rec_host_t *r,
  1799. xfs_filblks_t v)
  1800. {
  1801. ASSERT((v & XFS_MASK64HI(43)) == 0);
  1802. r->l1 = (r->l1 & (xfs_bmbt_rec_base_t)XFS_MASK64HI(43)) |
  1803. (xfs_bmbt_rec_base_t)(v & XFS_MASK64LO(21));
  1804. }
  1805. /*
  1806. * Set the startblock field in a bmap extent record.
  1807. */
  1808. void
  1809. xfs_bmbt_set_startblock(
  1810. xfs_bmbt_rec_host_t *r,
  1811. xfs_fsblock_t v)
  1812. {
  1813. #if XFS_BIG_BLKNOS
  1814. ASSERT((v & XFS_MASK64HI(12)) == 0);
  1815. r->l0 = (r->l0 & (xfs_bmbt_rec_base_t)XFS_MASK64HI(55)) |
  1816. (xfs_bmbt_rec_base_t)(v >> 43);
  1817. r->l1 = (r->l1 & (xfs_bmbt_rec_base_t)XFS_MASK64LO(21)) |
  1818. (xfs_bmbt_rec_base_t)(v << 21);
  1819. #else /* !XFS_BIG_BLKNOS */
  1820. if (ISNULLSTARTBLOCK(v)) {
  1821. r->l0 |= (xfs_bmbt_rec_base_t)XFS_MASK64LO(9);
  1822. r->l1 = (xfs_bmbt_rec_base_t)XFS_MASK64HI(11) |
  1823. ((xfs_bmbt_rec_base_t)v << 21) |
  1824. (r->l1 & (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  1825. } else {
  1826. r->l0 &= ~(xfs_bmbt_rec_base_t)XFS_MASK64LO(9);
  1827. r->l1 = ((xfs_bmbt_rec_base_t)v << 21) |
  1828. (r->l1 & (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  1829. }
  1830. #endif /* XFS_BIG_BLKNOS */
  1831. }
  1832. /*
  1833. * Set the startoff field in a bmap extent record.
  1834. */
  1835. void
  1836. xfs_bmbt_set_startoff(
  1837. xfs_bmbt_rec_host_t *r,
  1838. xfs_fileoff_t v)
  1839. {
  1840. ASSERT((v & XFS_MASK64HI(9)) == 0);
  1841. r->l0 = (r->l0 & (xfs_bmbt_rec_base_t) XFS_MASK64HI(1)) |
  1842. ((xfs_bmbt_rec_base_t)v << 9) |
  1843. (r->l0 & (xfs_bmbt_rec_base_t)XFS_MASK64LO(9));
  1844. }
  1845. /*
  1846. * Set the extent state field in a bmap extent record.
  1847. */
  1848. void
  1849. xfs_bmbt_set_state(
  1850. xfs_bmbt_rec_host_t *r,
  1851. xfs_exntst_t v)
  1852. {
  1853. ASSERT(v == XFS_EXT_NORM || v == XFS_EXT_UNWRITTEN);
  1854. if (v == XFS_EXT_NORM)
  1855. r->l0 &= XFS_MASK64LO(64 - BMBT_EXNTFLAG_BITLEN);
  1856. else
  1857. r->l0 |= XFS_MASK64HI(BMBT_EXNTFLAG_BITLEN);
  1858. }
  1859. /*
  1860. * Convert in-memory form of btree root to on-disk form.
  1861. */
  1862. void
  1863. xfs_bmbt_to_bmdr(
  1864. xfs_bmbt_block_t *rblock,
  1865. int rblocklen,
  1866. xfs_bmdr_block_t *dblock,
  1867. int dblocklen)
  1868. {
  1869. int dmxr;
  1870. xfs_bmbt_key_t *fkp;
  1871. __be64 *fpp;
  1872. xfs_bmbt_key_t *tkp;
  1873. __be64 *tpp;
  1874. ASSERT(be32_to_cpu(rblock->bb_magic) == XFS_BMAP_MAGIC);
  1875. ASSERT(be64_to_cpu(rblock->bb_leftsib) == NULLDFSBNO);
  1876. ASSERT(be64_to_cpu(rblock->bb_rightsib) == NULLDFSBNO);
  1877. ASSERT(be16_to_cpu(rblock->bb_level) > 0);
  1878. dblock->bb_level = rblock->bb_level;
  1879. dblock->bb_numrecs = rblock->bb_numrecs;
  1880. dmxr = (int)XFS_BTREE_BLOCK_MAXRECS(dblocklen, xfs_bmdr, 0);
  1881. fkp = XFS_BMAP_BROOT_KEY_ADDR(rblock, 1, rblocklen);
  1882. tkp = XFS_BTREE_KEY_ADDR(xfs_bmdr, dblock, 1);
  1883. fpp = XFS_BMAP_BROOT_PTR_ADDR(rblock, 1, rblocklen);
  1884. tpp = XFS_BTREE_PTR_ADDR(xfs_bmdr, dblock, 1, dmxr);
  1885. dmxr = be16_to_cpu(dblock->bb_numrecs);
  1886. memcpy(tkp, fkp, sizeof(*fkp) * dmxr);
  1887. memcpy(tpp, fpp, sizeof(*fpp) * dmxr);
  1888. }
  1889. /*
  1890. * Check extent records, which have just been read, for
  1891. * any bit in the extent flag field. ASSERT on debug
  1892. * kernels, as this condition should not occur.
  1893. * Return an error condition (1) if any flags found,
  1894. * otherwise return 0.
  1895. */
  1896. int
  1897. xfs_check_nostate_extents(
  1898. xfs_ifork_t *ifp,
  1899. xfs_extnum_t idx,
  1900. xfs_extnum_t num)
  1901. {
  1902. for (; num > 0; num--, idx++) {
  1903. xfs_bmbt_rec_host_t *ep = xfs_iext_get_ext(ifp, idx);
  1904. if ((ep->l0 >>
  1905. (64 - BMBT_EXNTFLAG_BITLEN)) != 0) {
  1906. ASSERT(0);
  1907. return 1;
  1908. }
  1909. }
  1910. return 0;
  1911. }
  1912. STATIC struct xfs_btree_cur *
  1913. xfs_bmbt_dup_cursor(
  1914. struct xfs_btree_cur *cur)
  1915. {
  1916. struct xfs_btree_cur *new;
  1917. new = xfs_bmbt_init_cursor(cur->bc_mp, cur->bc_tp,
  1918. cur->bc_private.b.ip, cur->bc_private.b.whichfork);
  1919. /*
  1920. * Copy the firstblock, flist, and flags values,
  1921. * since init cursor doesn't get them.
  1922. */
  1923. new->bc_private.b.firstblock = cur->bc_private.b.firstblock;
  1924. new->bc_private.b.flist = cur->bc_private.b.flist;
  1925. new->bc_private.b.flags = cur->bc_private.b.flags;
  1926. return new;
  1927. }
  1928. STATIC int
  1929. xfs_bmbt_get_maxrecs(
  1930. struct xfs_btree_cur *cur,
  1931. int level)
  1932. {
  1933. return XFS_BMAP_BLOCK_IMAXRECS(level, cur);
  1934. }
  1935. STATIC void
  1936. xfs_bmbt_init_key_from_rec(
  1937. union xfs_btree_key *key,
  1938. union xfs_btree_rec *rec)
  1939. {
  1940. key->bmbt.br_startoff =
  1941. cpu_to_be64(xfs_bmbt_disk_get_startoff(&rec->bmbt));
  1942. }
  1943. STATIC void
  1944. xfs_bmbt_init_ptr_from_cur(
  1945. struct xfs_btree_cur *cur,
  1946. union xfs_btree_ptr *ptr)
  1947. {
  1948. ptr->l = 0;
  1949. }
  1950. STATIC __int64_t
  1951. xfs_bmbt_key_diff(
  1952. struct xfs_btree_cur *cur,
  1953. union xfs_btree_key *key)
  1954. {
  1955. return (__int64_t)be64_to_cpu(key->bmbt.br_startoff) -
  1956. cur->bc_rec.b.br_startoff;
  1957. }
  1958. #ifdef XFS_BTREE_TRACE
  1959. ktrace_t *xfs_bmbt_trace_buf;
  1960. STATIC void
  1961. xfs_bmbt_trace_enter(
  1962. struct xfs_btree_cur *cur,
  1963. const char *func,
  1964. char *s,
  1965. int type,
  1966. int line,
  1967. __psunsigned_t a0,
  1968. __psunsigned_t a1,
  1969. __psunsigned_t a2,
  1970. __psunsigned_t a3,
  1971. __psunsigned_t a4,
  1972. __psunsigned_t a5,
  1973. __psunsigned_t a6,
  1974. __psunsigned_t a7,
  1975. __psunsigned_t a8,
  1976. __psunsigned_t a9,
  1977. __psunsigned_t a10)
  1978. {
  1979. struct xfs_inode *ip = cur->bc_private.b.ip;
  1980. int whichfork = cur->bc_private.b.whichfork;
  1981. ktrace_enter(xfs_bmbt_trace_buf,
  1982. (void *)((__psint_t)type | (whichfork << 8) | (line << 16)),
  1983. (void *)func, (void *)s, (void *)ip, (void *)cur,
  1984. (void *)a0, (void *)a1, (void *)a2, (void *)a3,
  1985. (void *)a4, (void *)a5, (void *)a6, (void *)a7,
  1986. (void *)a8, (void *)a9, (void *)a10);
  1987. ktrace_enter(ip->i_btrace,
  1988. (void *)((__psint_t)type | (whichfork << 8) | (line << 16)),
  1989. (void *)func, (void *)s, (void *)ip, (void *)cur,
  1990. (void *)a0, (void *)a1, (void *)a2, (void *)a3,
  1991. (void *)a4, (void *)a5, (void *)a6, (void *)a7,
  1992. (void *)a8, (void *)a9, (void *)a10);
  1993. }
  1994. STATIC void
  1995. xfs_bmbt_trace_cursor(
  1996. struct xfs_btree_cur *cur,
  1997. __uint32_t *s0,
  1998. __uint64_t *l0,
  1999. __uint64_t *l1)
  2000. {
  2001. struct xfs_bmbt_rec_host r;
  2002. xfs_bmbt_set_all(&r, &cur->bc_rec.b);
  2003. *s0 = (cur->bc_nlevels << 24) |
  2004. (cur->bc_private.b.flags << 16) |
  2005. cur->bc_private.b.allocated;
  2006. *l0 = r.l0;
  2007. *l1 = r.l1;
  2008. }
  2009. STATIC void
  2010. xfs_bmbt_trace_key(
  2011. struct xfs_btree_cur *cur,
  2012. union xfs_btree_key *key,
  2013. __uint64_t *l0,
  2014. __uint64_t *l1)
  2015. {
  2016. *l0 = be64_to_cpu(key->bmbt.br_startoff);
  2017. *l1 = 0;
  2018. }
  2019. STATIC void
  2020. xfs_bmbt_trace_record(
  2021. struct xfs_btree_cur *cur,
  2022. union xfs_btree_rec *rec,
  2023. __uint64_t *l0,
  2024. __uint64_t *l1,
  2025. __uint64_t *l2)
  2026. {
  2027. struct xfs_bmbt_irec irec;
  2028. xfs_bmbt_disk_get_all(&rec->bmbt, &irec);
  2029. *l0 = irec.br_startoff;
  2030. *l1 = irec.br_startblock;
  2031. *l2 = irec.br_blockcount;
  2032. }
  2033. #endif /* XFS_BTREE_TRACE */
  2034. static const struct xfs_btree_ops xfs_bmbt_ops = {
  2035. .rec_len = sizeof(xfs_bmbt_rec_t),
  2036. .key_len = sizeof(xfs_bmbt_key_t),
  2037. .dup_cursor = xfs_bmbt_dup_cursor,
  2038. .get_maxrecs = xfs_bmbt_get_maxrecs,
  2039. .init_key_from_rec = xfs_bmbt_init_key_from_rec,
  2040. .init_ptr_from_cur = xfs_bmbt_init_ptr_from_cur,
  2041. .key_diff = xfs_bmbt_key_diff,
  2042. #ifdef XFS_BTREE_TRACE
  2043. .trace_enter = xfs_bmbt_trace_enter,
  2044. .trace_cursor = xfs_bmbt_trace_cursor,
  2045. .trace_key = xfs_bmbt_trace_key,
  2046. .trace_record = xfs_bmbt_trace_record,
  2047. #endif
  2048. };
  2049. /*
  2050. * Allocate a new bmap btree cursor.
  2051. */
  2052. struct xfs_btree_cur * /* new bmap btree cursor */
  2053. xfs_bmbt_init_cursor(
  2054. struct xfs_mount *mp, /* file system mount point */
  2055. struct xfs_trans *tp, /* transaction pointer */
  2056. struct xfs_inode *ip, /* inode owning the btree */
  2057. int whichfork) /* data or attr fork */
  2058. {
  2059. struct xfs_ifork *ifp = XFS_IFORK_PTR(ip, whichfork);
  2060. struct xfs_btree_cur *cur;
  2061. cur = kmem_zone_zalloc(xfs_btree_cur_zone, KM_SLEEP);
  2062. cur->bc_tp = tp;
  2063. cur->bc_mp = mp;
  2064. cur->bc_nlevels = be16_to_cpu(ifp->if_broot->bb_level) + 1;
  2065. cur->bc_btnum = XFS_BTNUM_BMAP;
  2066. cur->bc_blocklog = mp->m_sb.sb_blocklog;
  2067. cur->bc_ops = &xfs_bmbt_ops;
  2068. cur->bc_flags = XFS_BTREE_LONG_PTRS | XFS_BTREE_ROOT_IN_INODE;
  2069. cur->bc_private.b.forksize = XFS_IFORK_SIZE(ip, whichfork);
  2070. cur->bc_private.b.ip = ip;
  2071. cur->bc_private.b.firstblock = NULLFSBLOCK;
  2072. cur->bc_private.b.flist = NULL;
  2073. cur->bc_private.b.allocated = 0;
  2074. cur->bc_private.b.flags = 0;
  2075. cur->bc_private.b.whichfork = whichfork;
  2076. return cur;
  2077. }