xfs_bmap_btree.c 69 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575
  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_ialloc.h"
  41. #include "xfs_itable.h"
  42. #include "xfs_bmap.h"
  43. #include "xfs_error.h"
  44. #include "xfs_quota.h"
  45. #if defined(XFS_BMBT_TRACE)
  46. ktrace_t *xfs_bmbt_trace_buf;
  47. #endif
  48. /*
  49. * Prototypes for internal btree functions.
  50. */
  51. STATIC int xfs_bmbt_killroot(xfs_btree_cur_t *);
  52. STATIC void xfs_bmbt_log_keys(xfs_btree_cur_t *, xfs_buf_t *, int, int);
  53. STATIC void xfs_bmbt_log_ptrs(xfs_btree_cur_t *, xfs_buf_t *, int, int);
  54. STATIC int xfs_bmbt_lshift(xfs_btree_cur_t *, int, int *);
  55. STATIC int xfs_bmbt_rshift(xfs_btree_cur_t *, int, int *);
  56. STATIC int xfs_bmbt_split(xfs_btree_cur_t *, int, xfs_fsblock_t *,
  57. __uint64_t *, xfs_btree_cur_t **, int *);
  58. STATIC int xfs_bmbt_updkey(xfs_btree_cur_t *, xfs_bmbt_key_t *, int);
  59. #if defined(XFS_BMBT_TRACE)
  60. static char ARGS[] = "args";
  61. static char ENTRY[] = "entry";
  62. static char ERROR[] = "error";
  63. #undef EXIT
  64. static char EXIT[] = "exit";
  65. /*
  66. * Add a trace buffer entry for the arguments given to the routine,
  67. * generic form.
  68. */
  69. STATIC void
  70. xfs_bmbt_trace_enter(
  71. const char *func,
  72. xfs_btree_cur_t *cur,
  73. char *s,
  74. int type,
  75. int line,
  76. __psunsigned_t a0,
  77. __psunsigned_t a1,
  78. __psunsigned_t a2,
  79. __psunsigned_t a3,
  80. __psunsigned_t a4,
  81. __psunsigned_t a5,
  82. __psunsigned_t a6,
  83. __psunsigned_t a7,
  84. __psunsigned_t a8,
  85. __psunsigned_t a9,
  86. __psunsigned_t a10)
  87. {
  88. xfs_inode_t *ip;
  89. int whichfork;
  90. ip = cur->bc_private.b.ip;
  91. whichfork = cur->bc_private.b.whichfork;
  92. ktrace_enter(xfs_bmbt_trace_buf,
  93. (void *)((__psint_t)type | (whichfork << 8) | (line << 16)),
  94. (void *)func, (void *)s, (void *)ip, (void *)cur,
  95. (void *)a0, (void *)a1, (void *)a2, (void *)a3,
  96. (void *)a4, (void *)a5, (void *)a6, (void *)a7,
  97. (void *)a8, (void *)a9, (void *)a10);
  98. ASSERT(ip->i_btrace);
  99. ktrace_enter(ip->i_btrace,
  100. (void *)((__psint_t)type | (whichfork << 8) | (line << 16)),
  101. (void *)func, (void *)s, (void *)ip, (void *)cur,
  102. (void *)a0, (void *)a1, (void *)a2, (void *)a3,
  103. (void *)a4, (void *)a5, (void *)a6, (void *)a7,
  104. (void *)a8, (void *)a9, (void *)a10);
  105. }
  106. /*
  107. * Add a trace buffer entry for arguments, for a buffer & 1 integer arg.
  108. */
  109. STATIC void
  110. xfs_bmbt_trace_argbi(
  111. const char *func,
  112. xfs_btree_cur_t *cur,
  113. xfs_buf_t *b,
  114. int i,
  115. int line)
  116. {
  117. xfs_bmbt_trace_enter(func, cur, ARGS, XFS_BMBT_KTRACE_ARGBI, line,
  118. (__psunsigned_t)b, i, 0, 0,
  119. 0, 0, 0, 0,
  120. 0, 0, 0);
  121. }
  122. /*
  123. * Add a trace buffer entry for arguments, for a buffer & 2 integer args.
  124. */
  125. STATIC void
  126. xfs_bmbt_trace_argbii(
  127. const char *func,
  128. xfs_btree_cur_t *cur,
  129. xfs_buf_t *b,
  130. int i0,
  131. int i1,
  132. int line)
  133. {
  134. xfs_bmbt_trace_enter(func, cur, ARGS, XFS_BMBT_KTRACE_ARGBII, line,
  135. (__psunsigned_t)b, i0, i1, 0,
  136. 0, 0, 0, 0,
  137. 0, 0, 0);
  138. }
  139. /*
  140. * Add a trace buffer entry for arguments, for 3 block-length args
  141. * and an integer arg.
  142. */
  143. STATIC void
  144. xfs_bmbt_trace_argfffi(
  145. const char *func,
  146. xfs_btree_cur_t *cur,
  147. xfs_dfiloff_t o,
  148. xfs_dfsbno_t b,
  149. xfs_dfilblks_t i,
  150. int j,
  151. int line)
  152. {
  153. xfs_bmbt_trace_enter(func, cur, ARGS, XFS_BMBT_KTRACE_ARGFFFI, line,
  154. o >> 32, (int)o, b >> 32, (int)b,
  155. i >> 32, (int)i, (int)j, 0,
  156. 0, 0, 0);
  157. }
  158. /*
  159. * Add a trace buffer entry for arguments, for one integer arg.
  160. */
  161. STATIC void
  162. xfs_bmbt_trace_argi(
  163. const char *func,
  164. xfs_btree_cur_t *cur,
  165. int i,
  166. int line)
  167. {
  168. xfs_bmbt_trace_enter(func, cur, ARGS, XFS_BMBT_KTRACE_ARGI, line,
  169. i, 0, 0, 0,
  170. 0, 0, 0, 0,
  171. 0, 0, 0);
  172. }
  173. /*
  174. * Add a trace buffer entry for arguments, for int, fsblock, key.
  175. */
  176. STATIC void
  177. xfs_bmbt_trace_argifk(
  178. const char *func,
  179. xfs_btree_cur_t *cur,
  180. int i,
  181. xfs_fsblock_t f,
  182. xfs_dfiloff_t o,
  183. int line)
  184. {
  185. xfs_bmbt_trace_enter(func, cur, ARGS, XFS_BMBT_KTRACE_ARGIFK, line,
  186. i, (xfs_dfsbno_t)f >> 32, (int)f, o >> 32,
  187. (int)o, 0, 0, 0,
  188. 0, 0, 0);
  189. }
  190. /*
  191. * Add a trace buffer entry for arguments, for int, fsblock, rec.
  192. */
  193. STATIC void
  194. xfs_bmbt_trace_argifr(
  195. const char *func,
  196. xfs_btree_cur_t *cur,
  197. int i,
  198. xfs_fsblock_t f,
  199. xfs_bmbt_rec_t *r,
  200. int line)
  201. {
  202. xfs_dfsbno_t b;
  203. xfs_dfilblks_t c;
  204. xfs_dfsbno_t d;
  205. xfs_dfiloff_t o;
  206. xfs_bmbt_irec_t s;
  207. d = (xfs_dfsbno_t)f;
  208. xfs_bmbt_disk_get_all(r, &s);
  209. o = (xfs_dfiloff_t)s.br_startoff;
  210. b = (xfs_dfsbno_t)s.br_startblock;
  211. c = s.br_blockcount;
  212. xfs_bmbt_trace_enter(func, cur, ARGS, XFS_BMBT_KTRACE_ARGIFR, line,
  213. i, d >> 32, (int)d, o >> 32,
  214. (int)o, b >> 32, (int)b, c >> 32,
  215. (int)c, 0, 0);
  216. }
  217. /*
  218. * Add a trace buffer entry for arguments, for int, key.
  219. */
  220. STATIC void
  221. xfs_bmbt_trace_argik(
  222. const char *func,
  223. xfs_btree_cur_t *cur,
  224. int i,
  225. xfs_bmbt_key_t *k,
  226. int line)
  227. {
  228. xfs_dfiloff_t o;
  229. o = be64_to_cpu(k->br_startoff);
  230. xfs_bmbt_trace_enter(func, cur, ARGS, XFS_BMBT_KTRACE_ARGIFK, line,
  231. i, o >> 32, (int)o, 0,
  232. 0, 0, 0, 0,
  233. 0, 0, 0);
  234. }
  235. /*
  236. * Add a trace buffer entry for the cursor/operation.
  237. */
  238. STATIC void
  239. xfs_bmbt_trace_cursor(
  240. const char *func,
  241. xfs_btree_cur_t *cur,
  242. char *s,
  243. int line)
  244. {
  245. xfs_bmbt_rec_host_t r;
  246. xfs_bmbt_set_all(&r, &cur->bc_rec.b);
  247. xfs_bmbt_trace_enter(func, cur, s, XFS_BMBT_KTRACE_CUR, line,
  248. (cur->bc_nlevels << 24) | (cur->bc_private.b.flags << 16) |
  249. cur->bc_private.b.allocated,
  250. r.l0 >> 32, (int)r.l0,
  251. r.l1 >> 32, (int)r.l1,
  252. (unsigned long)cur->bc_bufs[0], (unsigned long)cur->bc_bufs[1],
  253. (unsigned long)cur->bc_bufs[2], (unsigned long)cur->bc_bufs[3],
  254. (cur->bc_ptrs[0] << 16) | cur->bc_ptrs[1],
  255. (cur->bc_ptrs[2] << 16) | cur->bc_ptrs[3]);
  256. }
  257. #define XFS_BMBT_TRACE_ARGBI(c,b,i) \
  258. xfs_bmbt_trace_argbi(__FUNCTION__, c, b, i, __LINE__)
  259. #define XFS_BMBT_TRACE_ARGBII(c,b,i,j) \
  260. xfs_bmbt_trace_argbii(__FUNCTION__, c, b, i, j, __LINE__)
  261. #define XFS_BMBT_TRACE_ARGFFFI(c,o,b,i,j) \
  262. xfs_bmbt_trace_argfffi(__FUNCTION__, c, o, b, i, j, __LINE__)
  263. #define XFS_BMBT_TRACE_ARGI(c,i) \
  264. xfs_bmbt_trace_argi(__FUNCTION__, c, i, __LINE__)
  265. #define XFS_BMBT_TRACE_ARGIFK(c,i,f,s) \
  266. xfs_bmbt_trace_argifk(__FUNCTION__, c, i, f, s, __LINE__)
  267. #define XFS_BMBT_TRACE_ARGIFR(c,i,f,r) \
  268. xfs_bmbt_trace_argifr(__FUNCTION__, c, i, f, r, __LINE__)
  269. #define XFS_BMBT_TRACE_ARGIK(c,i,k) \
  270. xfs_bmbt_trace_argik(__FUNCTION__, c, i, k, __LINE__)
  271. #define XFS_BMBT_TRACE_CURSOR(c,s) \
  272. xfs_bmbt_trace_cursor(__FUNCTION__, c, s, __LINE__)
  273. #else
  274. #define XFS_BMBT_TRACE_ARGBI(c,b,i)
  275. #define XFS_BMBT_TRACE_ARGBII(c,b,i,j)
  276. #define XFS_BMBT_TRACE_ARGFFFI(c,o,b,i,j)
  277. #define XFS_BMBT_TRACE_ARGI(c,i)
  278. #define XFS_BMBT_TRACE_ARGIFK(c,i,f,s)
  279. #define XFS_BMBT_TRACE_ARGIFR(c,i,f,r)
  280. #define XFS_BMBT_TRACE_ARGIK(c,i,k)
  281. #define XFS_BMBT_TRACE_CURSOR(c,s)
  282. #endif /* XFS_BMBT_TRACE */
  283. /*
  284. * Internal functions.
  285. */
  286. /*
  287. * Delete record pointed to by cur/level.
  288. */
  289. STATIC int /* error */
  290. xfs_bmbt_delrec(
  291. xfs_btree_cur_t *cur,
  292. int level,
  293. int *stat) /* success/failure */
  294. {
  295. xfs_bmbt_block_t *block; /* bmap btree block */
  296. xfs_fsblock_t bno; /* fs-relative block number */
  297. xfs_buf_t *bp; /* buffer for block */
  298. int error; /* error return value */
  299. int i; /* loop counter */
  300. int j; /* temp state */
  301. xfs_bmbt_key_t key; /* bmap btree key */
  302. xfs_bmbt_key_t *kp=NULL; /* pointer to bmap btree key */
  303. xfs_fsblock_t lbno; /* left sibling block number */
  304. xfs_buf_t *lbp; /* left buffer pointer */
  305. xfs_bmbt_block_t *left; /* left btree block */
  306. xfs_bmbt_key_t *lkp; /* left btree key */
  307. xfs_bmbt_ptr_t *lpp; /* left address pointer */
  308. int lrecs=0; /* left record count */
  309. xfs_bmbt_rec_t *lrp; /* left record pointer */
  310. xfs_mount_t *mp; /* file system mount point */
  311. xfs_bmbt_ptr_t *pp; /* pointer to bmap block addr */
  312. int ptr; /* key/record index */
  313. xfs_fsblock_t rbno; /* right sibling block number */
  314. xfs_buf_t *rbp; /* right buffer pointer */
  315. xfs_bmbt_block_t *right; /* right btree block */
  316. xfs_bmbt_key_t *rkp; /* right btree key */
  317. xfs_bmbt_rec_t *rp; /* pointer to bmap btree rec */
  318. xfs_bmbt_ptr_t *rpp; /* right address pointer */
  319. xfs_bmbt_block_t *rrblock; /* right-right btree block */
  320. xfs_buf_t *rrbp; /* right-right buffer pointer */
  321. int rrecs=0; /* right record count */
  322. xfs_bmbt_rec_t *rrp; /* right record pointer */
  323. xfs_btree_cur_t *tcur; /* temporary btree cursor */
  324. int numrecs; /* temporary numrec count */
  325. int numlrecs, numrrecs;
  326. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  327. XFS_BMBT_TRACE_ARGI(cur, level);
  328. ptr = cur->bc_ptrs[level];
  329. tcur = NULL;
  330. if (ptr == 0) {
  331. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  332. *stat = 0;
  333. return 0;
  334. }
  335. block = xfs_bmbt_get_block(cur, level, &bp);
  336. numrecs = be16_to_cpu(block->bb_numrecs);
  337. #ifdef DEBUG
  338. if ((error = xfs_btree_check_lblock(cur, block, level, bp))) {
  339. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  340. goto error0;
  341. }
  342. #endif
  343. if (ptr > numrecs) {
  344. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  345. *stat = 0;
  346. return 0;
  347. }
  348. XFS_STATS_INC(xs_bmbt_delrec);
  349. if (level > 0) {
  350. kp = XFS_BMAP_KEY_IADDR(block, 1, cur);
  351. pp = XFS_BMAP_PTR_IADDR(block, 1, cur);
  352. #ifdef DEBUG
  353. for (i = ptr; i < numrecs; i++) {
  354. if ((error = xfs_btree_check_lptr_disk(cur, pp[i], level))) {
  355. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  356. goto error0;
  357. }
  358. }
  359. #endif
  360. if (ptr < numrecs) {
  361. memmove(&kp[ptr - 1], &kp[ptr],
  362. (numrecs - ptr) * sizeof(*kp));
  363. memmove(&pp[ptr - 1], &pp[ptr],
  364. (numrecs - ptr) * sizeof(*pp));
  365. xfs_bmbt_log_ptrs(cur, bp, ptr, numrecs - 1);
  366. xfs_bmbt_log_keys(cur, bp, ptr, numrecs - 1);
  367. }
  368. } else {
  369. rp = XFS_BMAP_REC_IADDR(block, 1, cur);
  370. if (ptr < numrecs) {
  371. memmove(&rp[ptr - 1], &rp[ptr],
  372. (numrecs - ptr) * sizeof(*rp));
  373. xfs_bmbt_log_recs(cur, bp, ptr, numrecs - 1);
  374. }
  375. if (ptr == 1) {
  376. key.br_startoff =
  377. cpu_to_be64(xfs_bmbt_disk_get_startoff(rp));
  378. kp = &key;
  379. }
  380. }
  381. numrecs--;
  382. block->bb_numrecs = cpu_to_be16(numrecs);
  383. xfs_bmbt_log_block(cur, bp, XFS_BB_NUMRECS);
  384. /*
  385. * We're at the root level.
  386. * First, shrink the root block in-memory.
  387. * Try to get rid of the next level down.
  388. * If we can't then there's nothing left to do.
  389. */
  390. if (level == cur->bc_nlevels - 1) {
  391. xfs_iroot_realloc(cur->bc_private.b.ip, -1,
  392. cur->bc_private.b.whichfork);
  393. if ((error = xfs_bmbt_killroot(cur))) {
  394. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  395. goto error0;
  396. }
  397. if (level > 0 && (error = xfs_bmbt_decrement(cur, level, &j))) {
  398. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  399. goto error0;
  400. }
  401. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  402. *stat = 1;
  403. return 0;
  404. }
  405. if (ptr == 1 && (error = xfs_bmbt_updkey(cur, kp, level + 1))) {
  406. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  407. goto error0;
  408. }
  409. if (numrecs >= XFS_BMAP_BLOCK_IMINRECS(level, cur)) {
  410. if (level > 0 && (error = xfs_bmbt_decrement(cur, level, &j))) {
  411. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  412. goto error0;
  413. }
  414. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  415. *stat = 1;
  416. return 0;
  417. }
  418. rbno = be64_to_cpu(block->bb_rightsib);
  419. lbno = be64_to_cpu(block->bb_leftsib);
  420. /*
  421. * One child of root, need to get a chance to copy its contents
  422. * into the root and delete it. Can't go up to next level,
  423. * there's nothing to delete there.
  424. */
  425. if (lbno == NULLFSBLOCK && rbno == NULLFSBLOCK &&
  426. level == cur->bc_nlevels - 2) {
  427. if ((error = xfs_bmbt_killroot(cur))) {
  428. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  429. goto error0;
  430. }
  431. if (level > 0 && (error = xfs_bmbt_decrement(cur, level, &i))) {
  432. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  433. goto error0;
  434. }
  435. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  436. *stat = 1;
  437. return 0;
  438. }
  439. ASSERT(rbno != NULLFSBLOCK || lbno != NULLFSBLOCK);
  440. if ((error = xfs_btree_dup_cursor(cur, &tcur))) {
  441. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  442. goto error0;
  443. }
  444. bno = NULLFSBLOCK;
  445. if (rbno != NULLFSBLOCK) {
  446. i = xfs_btree_lastrec(tcur, level);
  447. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  448. if ((error = xfs_bmbt_increment(tcur, level, &i))) {
  449. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  450. goto error0;
  451. }
  452. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  453. i = xfs_btree_lastrec(tcur, level);
  454. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  455. rbp = tcur->bc_bufs[level];
  456. right = XFS_BUF_TO_BMBT_BLOCK(rbp);
  457. #ifdef DEBUG
  458. if ((error = xfs_btree_check_lblock(cur, right, level, rbp))) {
  459. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  460. goto error0;
  461. }
  462. #endif
  463. bno = be64_to_cpu(right->bb_leftsib);
  464. if (be16_to_cpu(right->bb_numrecs) - 1 >=
  465. XFS_BMAP_BLOCK_IMINRECS(level, cur)) {
  466. if ((error = xfs_bmbt_lshift(tcur, level, &i))) {
  467. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  468. goto error0;
  469. }
  470. if (i) {
  471. ASSERT(be16_to_cpu(block->bb_numrecs) >=
  472. XFS_BMAP_BLOCK_IMINRECS(level, tcur));
  473. xfs_btree_del_cursor(tcur, XFS_BTREE_NOERROR);
  474. tcur = NULL;
  475. if (level > 0) {
  476. if ((error = xfs_bmbt_decrement(cur,
  477. level, &i))) {
  478. XFS_BMBT_TRACE_CURSOR(cur,
  479. ERROR);
  480. goto error0;
  481. }
  482. }
  483. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  484. *stat = 1;
  485. return 0;
  486. }
  487. }
  488. rrecs = be16_to_cpu(right->bb_numrecs);
  489. if (lbno != NULLFSBLOCK) {
  490. i = xfs_btree_firstrec(tcur, level);
  491. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  492. if ((error = xfs_bmbt_decrement(tcur, level, &i))) {
  493. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  494. goto error0;
  495. }
  496. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  497. }
  498. }
  499. if (lbno != NULLFSBLOCK) {
  500. i = xfs_btree_firstrec(tcur, level);
  501. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  502. /*
  503. * decrement to last in block
  504. */
  505. if ((error = xfs_bmbt_decrement(tcur, level, &i))) {
  506. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  507. goto error0;
  508. }
  509. i = xfs_btree_firstrec(tcur, level);
  510. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  511. lbp = tcur->bc_bufs[level];
  512. left = XFS_BUF_TO_BMBT_BLOCK(lbp);
  513. #ifdef DEBUG
  514. if ((error = xfs_btree_check_lblock(cur, left, level, lbp))) {
  515. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  516. goto error0;
  517. }
  518. #endif
  519. bno = be64_to_cpu(left->bb_rightsib);
  520. if (be16_to_cpu(left->bb_numrecs) - 1 >=
  521. XFS_BMAP_BLOCK_IMINRECS(level, cur)) {
  522. if ((error = xfs_bmbt_rshift(tcur, level, &i))) {
  523. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  524. goto error0;
  525. }
  526. if (i) {
  527. ASSERT(be16_to_cpu(block->bb_numrecs) >=
  528. XFS_BMAP_BLOCK_IMINRECS(level, tcur));
  529. xfs_btree_del_cursor(tcur, XFS_BTREE_NOERROR);
  530. tcur = NULL;
  531. if (level == 0)
  532. cur->bc_ptrs[0]++;
  533. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  534. *stat = 1;
  535. return 0;
  536. }
  537. }
  538. lrecs = be16_to_cpu(left->bb_numrecs);
  539. }
  540. xfs_btree_del_cursor(tcur, XFS_BTREE_NOERROR);
  541. tcur = NULL;
  542. mp = cur->bc_mp;
  543. ASSERT(bno != NULLFSBLOCK);
  544. if (lbno != NULLFSBLOCK &&
  545. lrecs + be16_to_cpu(block->bb_numrecs) <= XFS_BMAP_BLOCK_IMAXRECS(level, cur)) {
  546. rbno = bno;
  547. right = block;
  548. rbp = bp;
  549. if ((error = xfs_btree_read_bufl(mp, cur->bc_tp, lbno, 0, &lbp,
  550. XFS_BMAP_BTREE_REF))) {
  551. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  552. goto error0;
  553. }
  554. left = XFS_BUF_TO_BMBT_BLOCK(lbp);
  555. if ((error = xfs_btree_check_lblock(cur, left, level, lbp))) {
  556. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  557. goto error0;
  558. }
  559. } else if (rbno != NULLFSBLOCK &&
  560. rrecs + be16_to_cpu(block->bb_numrecs) <=
  561. XFS_BMAP_BLOCK_IMAXRECS(level, cur)) {
  562. lbno = bno;
  563. left = block;
  564. lbp = bp;
  565. if ((error = xfs_btree_read_bufl(mp, cur->bc_tp, rbno, 0, &rbp,
  566. XFS_BMAP_BTREE_REF))) {
  567. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  568. goto error0;
  569. }
  570. right = XFS_BUF_TO_BMBT_BLOCK(rbp);
  571. if ((error = xfs_btree_check_lblock(cur, right, level, rbp))) {
  572. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  573. goto error0;
  574. }
  575. lrecs = be16_to_cpu(left->bb_numrecs);
  576. } else {
  577. if (level > 0 && (error = xfs_bmbt_decrement(cur, level, &i))) {
  578. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  579. goto error0;
  580. }
  581. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  582. *stat = 1;
  583. return 0;
  584. }
  585. numlrecs = be16_to_cpu(left->bb_numrecs);
  586. numrrecs = be16_to_cpu(right->bb_numrecs);
  587. if (level > 0) {
  588. lkp = XFS_BMAP_KEY_IADDR(left, numlrecs + 1, cur);
  589. lpp = XFS_BMAP_PTR_IADDR(left, numlrecs + 1, cur);
  590. rkp = XFS_BMAP_KEY_IADDR(right, 1, cur);
  591. rpp = XFS_BMAP_PTR_IADDR(right, 1, cur);
  592. #ifdef DEBUG
  593. for (i = 0; i < numrrecs; i++) {
  594. if ((error = xfs_btree_check_lptr_disk(cur, rpp[i], level))) {
  595. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  596. goto error0;
  597. }
  598. }
  599. #endif
  600. memcpy(lkp, rkp, numrrecs * sizeof(*lkp));
  601. memcpy(lpp, rpp, numrrecs * sizeof(*lpp));
  602. xfs_bmbt_log_keys(cur, lbp, numlrecs + 1, numlrecs + numrrecs);
  603. xfs_bmbt_log_ptrs(cur, lbp, numlrecs + 1, numlrecs + numrrecs);
  604. } else {
  605. lrp = XFS_BMAP_REC_IADDR(left, numlrecs + 1, cur);
  606. rrp = XFS_BMAP_REC_IADDR(right, 1, cur);
  607. memcpy(lrp, rrp, numrrecs * sizeof(*lrp));
  608. xfs_bmbt_log_recs(cur, lbp, numlrecs + 1, numlrecs + numrrecs);
  609. }
  610. be16_add(&left->bb_numrecs, numrrecs);
  611. left->bb_rightsib = right->bb_rightsib;
  612. xfs_bmbt_log_block(cur, lbp, XFS_BB_RIGHTSIB | XFS_BB_NUMRECS);
  613. if (be64_to_cpu(left->bb_rightsib) != NULLDFSBNO) {
  614. if ((error = xfs_btree_read_bufl(mp, cur->bc_tp,
  615. be64_to_cpu(left->bb_rightsib),
  616. 0, &rrbp, XFS_BMAP_BTREE_REF))) {
  617. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  618. goto error0;
  619. }
  620. rrblock = XFS_BUF_TO_BMBT_BLOCK(rrbp);
  621. if ((error = xfs_btree_check_lblock(cur, rrblock, level, rrbp))) {
  622. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  623. goto error0;
  624. }
  625. rrblock->bb_leftsib = cpu_to_be64(lbno);
  626. xfs_bmbt_log_block(cur, rrbp, XFS_BB_LEFTSIB);
  627. }
  628. xfs_bmap_add_free(XFS_DADDR_TO_FSB(mp, XFS_BUF_ADDR(rbp)), 1,
  629. cur->bc_private.b.flist, mp);
  630. cur->bc_private.b.ip->i_d.di_nblocks--;
  631. xfs_trans_log_inode(cur->bc_tp, cur->bc_private.b.ip, XFS_ILOG_CORE);
  632. XFS_TRANS_MOD_DQUOT_BYINO(mp, cur->bc_tp, cur->bc_private.b.ip,
  633. XFS_TRANS_DQ_BCOUNT, -1L);
  634. xfs_trans_binval(cur->bc_tp, rbp);
  635. if (bp != lbp) {
  636. cur->bc_bufs[level] = lbp;
  637. cur->bc_ptrs[level] += lrecs;
  638. cur->bc_ra[level] = 0;
  639. } else if ((error = xfs_bmbt_increment(cur, level + 1, &i))) {
  640. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  641. goto error0;
  642. }
  643. if (level > 0)
  644. cur->bc_ptrs[level]--;
  645. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  646. *stat = 2;
  647. return 0;
  648. error0:
  649. if (tcur)
  650. xfs_btree_del_cursor(tcur, XFS_BTREE_ERROR);
  651. return error;
  652. }
  653. /*
  654. * Insert one record/level. Return information to the caller
  655. * allowing the next level up to proceed if necessary.
  656. */
  657. STATIC int /* error */
  658. xfs_bmbt_insrec(
  659. xfs_btree_cur_t *cur,
  660. int level,
  661. xfs_fsblock_t *bnop,
  662. xfs_bmbt_rec_t *recp,
  663. xfs_btree_cur_t **curp,
  664. int *stat) /* no-go/done/continue */
  665. {
  666. xfs_bmbt_block_t *block; /* bmap btree block */
  667. xfs_buf_t *bp; /* buffer for block */
  668. int error; /* error return value */
  669. int i; /* loop index */
  670. xfs_bmbt_key_t key; /* bmap btree key */
  671. xfs_bmbt_key_t *kp=NULL; /* pointer to bmap btree key */
  672. int logflags; /* inode logging flags */
  673. xfs_fsblock_t nbno; /* new block number */
  674. struct xfs_btree_cur *ncur; /* new btree cursor */
  675. __uint64_t startoff; /* new btree key value */
  676. xfs_bmbt_rec_t nrec; /* new record count */
  677. int optr; /* old key/record index */
  678. xfs_bmbt_ptr_t *pp; /* pointer to bmap block addr */
  679. int ptr; /* key/record index */
  680. xfs_bmbt_rec_t *rp=NULL; /* pointer to bmap btree rec */
  681. int numrecs;
  682. ASSERT(level < cur->bc_nlevels);
  683. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  684. XFS_BMBT_TRACE_ARGIFR(cur, level, *bnop, recp);
  685. ncur = NULL;
  686. key.br_startoff = cpu_to_be64(xfs_bmbt_disk_get_startoff(recp));
  687. optr = ptr = cur->bc_ptrs[level];
  688. if (ptr == 0) {
  689. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  690. *stat = 0;
  691. return 0;
  692. }
  693. XFS_STATS_INC(xs_bmbt_insrec);
  694. block = xfs_bmbt_get_block(cur, level, &bp);
  695. numrecs = be16_to_cpu(block->bb_numrecs);
  696. #ifdef DEBUG
  697. if ((error = xfs_btree_check_lblock(cur, block, level, bp))) {
  698. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  699. return error;
  700. }
  701. if (ptr <= numrecs) {
  702. if (level == 0) {
  703. rp = XFS_BMAP_REC_IADDR(block, ptr, cur);
  704. xfs_btree_check_rec(XFS_BTNUM_BMAP, recp, rp);
  705. } else {
  706. kp = XFS_BMAP_KEY_IADDR(block, ptr, cur);
  707. xfs_btree_check_key(XFS_BTNUM_BMAP, &key, kp);
  708. }
  709. }
  710. #endif
  711. nbno = NULLFSBLOCK;
  712. if (numrecs == XFS_BMAP_BLOCK_IMAXRECS(level, cur)) {
  713. if (numrecs < XFS_BMAP_BLOCK_DMAXRECS(level, cur)) {
  714. /*
  715. * A root block, that can be made bigger.
  716. */
  717. xfs_iroot_realloc(cur->bc_private.b.ip, 1,
  718. cur->bc_private.b.whichfork);
  719. block = xfs_bmbt_get_block(cur, level, &bp);
  720. } else if (level == cur->bc_nlevels - 1) {
  721. if ((error = xfs_bmbt_newroot(cur, &logflags, stat)) ||
  722. *stat == 0) {
  723. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  724. return error;
  725. }
  726. xfs_trans_log_inode(cur->bc_tp, cur->bc_private.b.ip,
  727. logflags);
  728. block = xfs_bmbt_get_block(cur, level, &bp);
  729. } else {
  730. if ((error = xfs_bmbt_rshift(cur, level, &i))) {
  731. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  732. return error;
  733. }
  734. if (i) {
  735. /* nothing */
  736. } else {
  737. if ((error = xfs_bmbt_lshift(cur, level, &i))) {
  738. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  739. return error;
  740. }
  741. if (i) {
  742. optr = ptr = cur->bc_ptrs[level];
  743. } else {
  744. if ((error = xfs_bmbt_split(cur, level,
  745. &nbno, &startoff, &ncur,
  746. &i))) {
  747. XFS_BMBT_TRACE_CURSOR(cur,
  748. ERROR);
  749. return error;
  750. }
  751. if (i) {
  752. block = xfs_bmbt_get_block(
  753. cur, level, &bp);
  754. #ifdef DEBUG
  755. if ((error =
  756. xfs_btree_check_lblock(cur,
  757. block, level, bp))) {
  758. XFS_BMBT_TRACE_CURSOR(
  759. cur, ERROR);
  760. return error;
  761. }
  762. #endif
  763. ptr = cur->bc_ptrs[level];
  764. xfs_bmbt_disk_set_allf(&nrec,
  765. startoff, 0, 0,
  766. XFS_EXT_NORM);
  767. } else {
  768. XFS_BMBT_TRACE_CURSOR(cur,
  769. EXIT);
  770. *stat = 0;
  771. return 0;
  772. }
  773. }
  774. }
  775. }
  776. }
  777. numrecs = be16_to_cpu(block->bb_numrecs);
  778. if (level > 0) {
  779. kp = XFS_BMAP_KEY_IADDR(block, 1, cur);
  780. pp = XFS_BMAP_PTR_IADDR(block, 1, cur);
  781. #ifdef DEBUG
  782. for (i = numrecs; i >= ptr; i--) {
  783. if ((error = xfs_btree_check_lptr_disk(cur, pp[i - 1],
  784. level))) {
  785. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  786. return error;
  787. }
  788. }
  789. #endif
  790. memmove(&kp[ptr], &kp[ptr - 1],
  791. (numrecs - ptr + 1) * sizeof(*kp));
  792. memmove(&pp[ptr], &pp[ptr - 1],
  793. (numrecs - ptr + 1) * sizeof(*pp));
  794. #ifdef DEBUG
  795. if ((error = xfs_btree_check_lptr(cur, *bnop, level))) {
  796. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  797. return error;
  798. }
  799. #endif
  800. kp[ptr - 1] = key;
  801. pp[ptr - 1] = cpu_to_be64(*bnop);
  802. numrecs++;
  803. block->bb_numrecs = cpu_to_be16(numrecs);
  804. xfs_bmbt_log_keys(cur, bp, ptr, numrecs);
  805. xfs_bmbt_log_ptrs(cur, bp, ptr, numrecs);
  806. } else {
  807. rp = XFS_BMAP_REC_IADDR(block, 1, cur);
  808. memmove(&rp[ptr], &rp[ptr - 1],
  809. (numrecs - ptr + 1) * sizeof(*rp));
  810. rp[ptr - 1] = *recp;
  811. numrecs++;
  812. block->bb_numrecs = cpu_to_be16(numrecs);
  813. xfs_bmbt_log_recs(cur, bp, ptr, numrecs);
  814. }
  815. xfs_bmbt_log_block(cur, bp, XFS_BB_NUMRECS);
  816. #ifdef DEBUG
  817. if (ptr < numrecs) {
  818. if (level == 0)
  819. xfs_btree_check_rec(XFS_BTNUM_BMAP, rp + ptr - 1,
  820. rp + ptr);
  821. else
  822. xfs_btree_check_key(XFS_BTNUM_BMAP, kp + ptr - 1,
  823. kp + ptr);
  824. }
  825. #endif
  826. if (optr == 1 && (error = xfs_bmbt_updkey(cur, &key, level + 1))) {
  827. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  828. return error;
  829. }
  830. *bnop = nbno;
  831. if (nbno != NULLFSBLOCK) {
  832. *recp = nrec;
  833. *curp = ncur;
  834. }
  835. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  836. *stat = 1;
  837. return 0;
  838. }
  839. STATIC int
  840. xfs_bmbt_killroot(
  841. xfs_btree_cur_t *cur)
  842. {
  843. xfs_bmbt_block_t *block;
  844. xfs_bmbt_block_t *cblock;
  845. xfs_buf_t *cbp;
  846. xfs_bmbt_key_t *ckp;
  847. xfs_bmbt_ptr_t *cpp;
  848. #ifdef DEBUG
  849. int error;
  850. #endif
  851. int i;
  852. xfs_bmbt_key_t *kp;
  853. xfs_inode_t *ip;
  854. xfs_ifork_t *ifp;
  855. int level;
  856. xfs_bmbt_ptr_t *pp;
  857. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  858. level = cur->bc_nlevels - 1;
  859. ASSERT(level >= 1);
  860. /*
  861. * Don't deal with the root block needs to be a leaf case.
  862. * We're just going to turn the thing back into extents anyway.
  863. */
  864. if (level == 1) {
  865. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  866. return 0;
  867. }
  868. block = xfs_bmbt_get_block(cur, level, &cbp);
  869. /*
  870. * Give up if the root has multiple children.
  871. */
  872. if (be16_to_cpu(block->bb_numrecs) != 1) {
  873. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  874. return 0;
  875. }
  876. /*
  877. * Only do this if the next level will fit.
  878. * Then the data must be copied up to the inode,
  879. * instead of freeing the root you free the next level.
  880. */
  881. cbp = cur->bc_bufs[level - 1];
  882. cblock = XFS_BUF_TO_BMBT_BLOCK(cbp);
  883. if (be16_to_cpu(cblock->bb_numrecs) > XFS_BMAP_BLOCK_DMAXRECS(level, cur)) {
  884. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  885. return 0;
  886. }
  887. ASSERT(be64_to_cpu(cblock->bb_leftsib) == NULLDFSBNO);
  888. ASSERT(be64_to_cpu(cblock->bb_rightsib) == NULLDFSBNO);
  889. ip = cur->bc_private.b.ip;
  890. ifp = XFS_IFORK_PTR(ip, cur->bc_private.b.whichfork);
  891. ASSERT(XFS_BMAP_BLOCK_IMAXRECS(level, cur) ==
  892. XFS_BMAP_BROOT_MAXRECS(ifp->if_broot_bytes));
  893. i = (int)(be16_to_cpu(cblock->bb_numrecs) - XFS_BMAP_BLOCK_IMAXRECS(level, cur));
  894. if (i) {
  895. xfs_iroot_realloc(ip, i, cur->bc_private.b.whichfork);
  896. block = ifp->if_broot;
  897. }
  898. be16_add(&block->bb_numrecs, i);
  899. ASSERT(block->bb_numrecs == cblock->bb_numrecs);
  900. kp = XFS_BMAP_KEY_IADDR(block, 1, cur);
  901. ckp = XFS_BMAP_KEY_IADDR(cblock, 1, cur);
  902. memcpy(kp, ckp, be16_to_cpu(block->bb_numrecs) * sizeof(*kp));
  903. pp = XFS_BMAP_PTR_IADDR(block, 1, cur);
  904. cpp = XFS_BMAP_PTR_IADDR(cblock, 1, cur);
  905. #ifdef DEBUG
  906. for (i = 0; i < be16_to_cpu(cblock->bb_numrecs); i++) {
  907. if ((error = xfs_btree_check_lptr_disk(cur, cpp[i], level - 1))) {
  908. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  909. return error;
  910. }
  911. }
  912. #endif
  913. memcpy(pp, cpp, be16_to_cpu(block->bb_numrecs) * sizeof(*pp));
  914. xfs_bmap_add_free(XFS_DADDR_TO_FSB(cur->bc_mp, XFS_BUF_ADDR(cbp)), 1,
  915. cur->bc_private.b.flist, cur->bc_mp);
  916. ip->i_d.di_nblocks--;
  917. XFS_TRANS_MOD_DQUOT_BYINO(cur->bc_mp, cur->bc_tp, ip,
  918. XFS_TRANS_DQ_BCOUNT, -1L);
  919. xfs_trans_binval(cur->bc_tp, cbp);
  920. cur->bc_bufs[level - 1] = NULL;
  921. be16_add(&block->bb_level, -1);
  922. xfs_trans_log_inode(cur->bc_tp, ip,
  923. XFS_ILOG_CORE | XFS_ILOG_FBROOT(cur->bc_private.b.whichfork));
  924. cur->bc_nlevels--;
  925. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  926. return 0;
  927. }
  928. /*
  929. * Log key values from the btree block.
  930. */
  931. STATIC void
  932. xfs_bmbt_log_keys(
  933. xfs_btree_cur_t *cur,
  934. xfs_buf_t *bp,
  935. int kfirst,
  936. int klast)
  937. {
  938. xfs_trans_t *tp;
  939. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  940. XFS_BMBT_TRACE_ARGBII(cur, bp, kfirst, klast);
  941. tp = cur->bc_tp;
  942. if (bp) {
  943. xfs_bmbt_block_t *block;
  944. int first;
  945. xfs_bmbt_key_t *kp;
  946. int last;
  947. block = XFS_BUF_TO_BMBT_BLOCK(bp);
  948. kp = XFS_BMAP_KEY_DADDR(block, 1, cur);
  949. first = (int)((xfs_caddr_t)&kp[kfirst - 1] - (xfs_caddr_t)block);
  950. last = (int)(((xfs_caddr_t)&kp[klast] - 1) - (xfs_caddr_t)block);
  951. xfs_trans_log_buf(tp, bp, first, last);
  952. } else {
  953. xfs_inode_t *ip;
  954. ip = cur->bc_private.b.ip;
  955. xfs_trans_log_inode(tp, ip,
  956. XFS_ILOG_FBROOT(cur->bc_private.b.whichfork));
  957. }
  958. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  959. }
  960. /*
  961. * Log pointer values from the btree block.
  962. */
  963. STATIC void
  964. xfs_bmbt_log_ptrs(
  965. xfs_btree_cur_t *cur,
  966. xfs_buf_t *bp,
  967. int pfirst,
  968. int plast)
  969. {
  970. xfs_trans_t *tp;
  971. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  972. XFS_BMBT_TRACE_ARGBII(cur, bp, pfirst, plast);
  973. tp = cur->bc_tp;
  974. if (bp) {
  975. xfs_bmbt_block_t *block;
  976. int first;
  977. int last;
  978. xfs_bmbt_ptr_t *pp;
  979. block = XFS_BUF_TO_BMBT_BLOCK(bp);
  980. pp = XFS_BMAP_PTR_DADDR(block, 1, cur);
  981. first = (int)((xfs_caddr_t)&pp[pfirst - 1] - (xfs_caddr_t)block);
  982. last = (int)(((xfs_caddr_t)&pp[plast] - 1) - (xfs_caddr_t)block);
  983. xfs_trans_log_buf(tp, bp, first, last);
  984. } else {
  985. xfs_inode_t *ip;
  986. ip = cur->bc_private.b.ip;
  987. xfs_trans_log_inode(tp, ip,
  988. XFS_ILOG_FBROOT(cur->bc_private.b.whichfork));
  989. }
  990. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  991. }
  992. /*
  993. * Lookup the record. The cursor is made to point to it, based on dir.
  994. */
  995. STATIC int /* error */
  996. xfs_bmbt_lookup(
  997. xfs_btree_cur_t *cur,
  998. xfs_lookup_t dir,
  999. int *stat) /* success/failure */
  1000. {
  1001. xfs_bmbt_block_t *block=NULL;
  1002. xfs_buf_t *bp;
  1003. xfs_daddr_t d;
  1004. xfs_sfiloff_t diff;
  1005. int error; /* error return value */
  1006. xfs_fsblock_t fsbno=0;
  1007. int high;
  1008. int i;
  1009. int keyno=0;
  1010. xfs_bmbt_key_t *kkbase=NULL;
  1011. xfs_bmbt_key_t *kkp;
  1012. xfs_bmbt_rec_t *krbase=NULL;
  1013. xfs_bmbt_rec_t *krp;
  1014. int level;
  1015. int low;
  1016. xfs_mount_t *mp;
  1017. xfs_bmbt_ptr_t *pp;
  1018. xfs_bmbt_irec_t *rp;
  1019. xfs_fileoff_t startoff;
  1020. xfs_trans_t *tp;
  1021. XFS_STATS_INC(xs_bmbt_lookup);
  1022. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1023. XFS_BMBT_TRACE_ARGI(cur, (int)dir);
  1024. tp = cur->bc_tp;
  1025. mp = cur->bc_mp;
  1026. rp = &cur->bc_rec.b;
  1027. for (level = cur->bc_nlevels - 1, diff = 1; level >= 0; level--) {
  1028. if (level < cur->bc_nlevels - 1) {
  1029. d = XFS_FSB_TO_DADDR(mp, fsbno);
  1030. bp = cur->bc_bufs[level];
  1031. if (bp && XFS_BUF_ADDR(bp) != d)
  1032. bp = NULL;
  1033. if (!bp) {
  1034. if ((error = xfs_btree_read_bufl(mp, tp, fsbno,
  1035. 0, &bp, XFS_BMAP_BTREE_REF))) {
  1036. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1037. return error;
  1038. }
  1039. xfs_btree_setbuf(cur, level, bp);
  1040. block = XFS_BUF_TO_BMBT_BLOCK(bp);
  1041. if ((error = xfs_btree_check_lblock(cur, block,
  1042. level, bp))) {
  1043. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1044. return error;
  1045. }
  1046. } else
  1047. block = XFS_BUF_TO_BMBT_BLOCK(bp);
  1048. } else
  1049. block = xfs_bmbt_get_block(cur, level, &bp);
  1050. if (diff == 0)
  1051. keyno = 1;
  1052. else {
  1053. if (level > 0)
  1054. kkbase = XFS_BMAP_KEY_IADDR(block, 1, cur);
  1055. else
  1056. krbase = XFS_BMAP_REC_IADDR(block, 1, cur);
  1057. low = 1;
  1058. if (!(high = be16_to_cpu(block->bb_numrecs))) {
  1059. ASSERT(level == 0);
  1060. cur->bc_ptrs[0] = dir != XFS_LOOKUP_LE;
  1061. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1062. *stat = 0;
  1063. return 0;
  1064. }
  1065. while (low <= high) {
  1066. XFS_STATS_INC(xs_bmbt_compare);
  1067. keyno = (low + high) >> 1;
  1068. if (level > 0) {
  1069. kkp = kkbase + keyno - 1;
  1070. startoff = be64_to_cpu(kkp->br_startoff);
  1071. } else {
  1072. krp = krbase + keyno - 1;
  1073. startoff = xfs_bmbt_disk_get_startoff(krp);
  1074. }
  1075. diff = (xfs_sfiloff_t)
  1076. (startoff - rp->br_startoff);
  1077. if (diff < 0)
  1078. low = keyno + 1;
  1079. else if (diff > 0)
  1080. high = keyno - 1;
  1081. else
  1082. break;
  1083. }
  1084. }
  1085. if (level > 0) {
  1086. if (diff > 0 && --keyno < 1)
  1087. keyno = 1;
  1088. pp = XFS_BMAP_PTR_IADDR(block, keyno, cur);
  1089. fsbno = be64_to_cpu(*pp);
  1090. #ifdef DEBUG
  1091. if ((error = xfs_btree_check_lptr(cur, fsbno, level))) {
  1092. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1093. return error;
  1094. }
  1095. #endif
  1096. cur->bc_ptrs[level] = keyno;
  1097. }
  1098. }
  1099. if (dir != XFS_LOOKUP_LE && diff < 0) {
  1100. keyno++;
  1101. /*
  1102. * If ge search and we went off the end of the block, but it's
  1103. * not the last block, we're in the wrong block.
  1104. */
  1105. if (dir == XFS_LOOKUP_GE && keyno > be16_to_cpu(block->bb_numrecs) &&
  1106. be64_to_cpu(block->bb_rightsib) != NULLDFSBNO) {
  1107. cur->bc_ptrs[0] = keyno;
  1108. if ((error = xfs_bmbt_increment(cur, 0, &i))) {
  1109. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1110. return error;
  1111. }
  1112. XFS_WANT_CORRUPTED_RETURN(i == 1);
  1113. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1114. *stat = 1;
  1115. return 0;
  1116. }
  1117. }
  1118. else if (dir == XFS_LOOKUP_LE && diff > 0)
  1119. keyno--;
  1120. cur->bc_ptrs[0] = keyno;
  1121. if (keyno == 0 || keyno > be16_to_cpu(block->bb_numrecs)) {
  1122. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1123. *stat = 0;
  1124. } else {
  1125. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1126. *stat = ((dir != XFS_LOOKUP_EQ) || (diff == 0));
  1127. }
  1128. return 0;
  1129. }
  1130. /*
  1131. * Move 1 record left from cur/level if possible.
  1132. * Update cur to reflect the new path.
  1133. */
  1134. STATIC int /* error */
  1135. xfs_bmbt_lshift(
  1136. xfs_btree_cur_t *cur,
  1137. int level,
  1138. int *stat) /* success/failure */
  1139. {
  1140. int error; /* error return value */
  1141. #ifdef DEBUG
  1142. int i; /* loop counter */
  1143. #endif
  1144. xfs_bmbt_key_t key; /* bmap btree key */
  1145. xfs_buf_t *lbp; /* left buffer pointer */
  1146. xfs_bmbt_block_t *left; /* left btree block */
  1147. xfs_bmbt_key_t *lkp=NULL; /* left btree key */
  1148. xfs_bmbt_ptr_t *lpp; /* left address pointer */
  1149. int lrecs; /* left record count */
  1150. xfs_bmbt_rec_t *lrp=NULL; /* left record pointer */
  1151. xfs_mount_t *mp; /* file system mount point */
  1152. xfs_buf_t *rbp; /* right buffer pointer */
  1153. xfs_bmbt_block_t *right; /* right btree block */
  1154. xfs_bmbt_key_t *rkp=NULL; /* right btree key */
  1155. xfs_bmbt_ptr_t *rpp=NULL; /* right address pointer */
  1156. xfs_bmbt_rec_t *rrp=NULL; /* right record pointer */
  1157. int rrecs; /* right record count */
  1158. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1159. XFS_BMBT_TRACE_ARGI(cur, level);
  1160. if (level == cur->bc_nlevels - 1) {
  1161. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1162. *stat = 0;
  1163. return 0;
  1164. }
  1165. rbp = cur->bc_bufs[level];
  1166. right = XFS_BUF_TO_BMBT_BLOCK(rbp);
  1167. #ifdef DEBUG
  1168. if ((error = xfs_btree_check_lblock(cur, right, level, rbp))) {
  1169. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1170. return error;
  1171. }
  1172. #endif
  1173. if (be64_to_cpu(right->bb_leftsib) == NULLDFSBNO) {
  1174. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1175. *stat = 0;
  1176. return 0;
  1177. }
  1178. if (cur->bc_ptrs[level] <= 1) {
  1179. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1180. *stat = 0;
  1181. return 0;
  1182. }
  1183. mp = cur->bc_mp;
  1184. if ((error = xfs_btree_read_bufl(mp, cur->bc_tp, be64_to_cpu(right->bb_leftsib), 0,
  1185. &lbp, XFS_BMAP_BTREE_REF))) {
  1186. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1187. return error;
  1188. }
  1189. left = XFS_BUF_TO_BMBT_BLOCK(lbp);
  1190. if ((error = xfs_btree_check_lblock(cur, left, level, lbp))) {
  1191. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1192. return error;
  1193. }
  1194. if (be16_to_cpu(left->bb_numrecs) == XFS_BMAP_BLOCK_IMAXRECS(level, cur)) {
  1195. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1196. *stat = 0;
  1197. return 0;
  1198. }
  1199. lrecs = be16_to_cpu(left->bb_numrecs) + 1;
  1200. if (level > 0) {
  1201. lkp = XFS_BMAP_KEY_IADDR(left, lrecs, cur);
  1202. rkp = XFS_BMAP_KEY_IADDR(right, 1, cur);
  1203. *lkp = *rkp;
  1204. xfs_bmbt_log_keys(cur, lbp, lrecs, lrecs);
  1205. lpp = XFS_BMAP_PTR_IADDR(left, lrecs, cur);
  1206. rpp = XFS_BMAP_PTR_IADDR(right, 1, cur);
  1207. #ifdef DEBUG
  1208. if ((error = xfs_btree_check_lptr_disk(cur, *rpp, level))) {
  1209. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1210. return error;
  1211. }
  1212. #endif
  1213. *lpp = *rpp;
  1214. xfs_bmbt_log_ptrs(cur, lbp, lrecs, lrecs);
  1215. } else {
  1216. lrp = XFS_BMAP_REC_IADDR(left, lrecs, cur);
  1217. rrp = XFS_BMAP_REC_IADDR(right, 1, cur);
  1218. *lrp = *rrp;
  1219. xfs_bmbt_log_recs(cur, lbp, lrecs, lrecs);
  1220. }
  1221. left->bb_numrecs = cpu_to_be16(lrecs);
  1222. xfs_bmbt_log_block(cur, lbp, XFS_BB_NUMRECS);
  1223. #ifdef DEBUG
  1224. if (level > 0)
  1225. xfs_btree_check_key(XFS_BTNUM_BMAP, lkp - 1, lkp);
  1226. else
  1227. xfs_btree_check_rec(XFS_BTNUM_BMAP, lrp - 1, lrp);
  1228. #endif
  1229. rrecs = be16_to_cpu(right->bb_numrecs) - 1;
  1230. right->bb_numrecs = cpu_to_be16(rrecs);
  1231. xfs_bmbt_log_block(cur, rbp, XFS_BB_NUMRECS);
  1232. if (level > 0) {
  1233. #ifdef DEBUG
  1234. for (i = 0; i < rrecs; i++) {
  1235. if ((error = xfs_btree_check_lptr_disk(cur, rpp[i + 1],
  1236. level))) {
  1237. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1238. return error;
  1239. }
  1240. }
  1241. #endif
  1242. memmove(rkp, rkp + 1, rrecs * sizeof(*rkp));
  1243. memmove(rpp, rpp + 1, rrecs * sizeof(*rpp));
  1244. xfs_bmbt_log_keys(cur, rbp, 1, rrecs);
  1245. xfs_bmbt_log_ptrs(cur, rbp, 1, rrecs);
  1246. } else {
  1247. memmove(rrp, rrp + 1, rrecs * sizeof(*rrp));
  1248. xfs_bmbt_log_recs(cur, rbp, 1, rrecs);
  1249. key.br_startoff = cpu_to_be64(xfs_bmbt_disk_get_startoff(rrp));
  1250. rkp = &key;
  1251. }
  1252. if ((error = xfs_bmbt_updkey(cur, rkp, level + 1))) {
  1253. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1254. return error;
  1255. }
  1256. cur->bc_ptrs[level]--;
  1257. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1258. *stat = 1;
  1259. return 0;
  1260. }
  1261. /*
  1262. * Move 1 record right from cur/level if possible.
  1263. * Update cur to reflect the new path.
  1264. */
  1265. STATIC int /* error */
  1266. xfs_bmbt_rshift(
  1267. xfs_btree_cur_t *cur,
  1268. int level,
  1269. int *stat) /* success/failure */
  1270. {
  1271. int error; /* error return value */
  1272. int i; /* loop counter */
  1273. xfs_bmbt_key_t key; /* bmap btree key */
  1274. xfs_buf_t *lbp; /* left buffer pointer */
  1275. xfs_bmbt_block_t *left; /* left btree block */
  1276. xfs_bmbt_key_t *lkp; /* left btree key */
  1277. xfs_bmbt_ptr_t *lpp; /* left address pointer */
  1278. xfs_bmbt_rec_t *lrp; /* left record pointer */
  1279. xfs_mount_t *mp; /* file system mount point */
  1280. xfs_buf_t *rbp; /* right buffer pointer */
  1281. xfs_bmbt_block_t *right; /* right btree block */
  1282. xfs_bmbt_key_t *rkp; /* right btree key */
  1283. xfs_bmbt_ptr_t *rpp; /* right address pointer */
  1284. xfs_bmbt_rec_t *rrp=NULL; /* right record pointer */
  1285. struct xfs_btree_cur *tcur; /* temporary btree cursor */
  1286. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1287. XFS_BMBT_TRACE_ARGI(cur, level);
  1288. if (level == cur->bc_nlevels - 1) {
  1289. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1290. *stat = 0;
  1291. return 0;
  1292. }
  1293. lbp = cur->bc_bufs[level];
  1294. left = XFS_BUF_TO_BMBT_BLOCK(lbp);
  1295. #ifdef DEBUG
  1296. if ((error = xfs_btree_check_lblock(cur, left, level, lbp))) {
  1297. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1298. return error;
  1299. }
  1300. #endif
  1301. if (be64_to_cpu(left->bb_rightsib) == NULLDFSBNO) {
  1302. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1303. *stat = 0;
  1304. return 0;
  1305. }
  1306. if (cur->bc_ptrs[level] >= be16_to_cpu(left->bb_numrecs)) {
  1307. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1308. *stat = 0;
  1309. return 0;
  1310. }
  1311. mp = cur->bc_mp;
  1312. if ((error = xfs_btree_read_bufl(mp, cur->bc_tp, be64_to_cpu(left->bb_rightsib), 0,
  1313. &rbp, XFS_BMAP_BTREE_REF))) {
  1314. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1315. return error;
  1316. }
  1317. right = XFS_BUF_TO_BMBT_BLOCK(rbp);
  1318. if ((error = xfs_btree_check_lblock(cur, right, level, rbp))) {
  1319. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1320. return error;
  1321. }
  1322. if (be16_to_cpu(right->bb_numrecs) == XFS_BMAP_BLOCK_IMAXRECS(level, cur)) {
  1323. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1324. *stat = 0;
  1325. return 0;
  1326. }
  1327. if (level > 0) {
  1328. lkp = XFS_BMAP_KEY_IADDR(left, be16_to_cpu(left->bb_numrecs), cur);
  1329. lpp = XFS_BMAP_PTR_IADDR(left, be16_to_cpu(left->bb_numrecs), cur);
  1330. rkp = XFS_BMAP_KEY_IADDR(right, 1, cur);
  1331. rpp = XFS_BMAP_PTR_IADDR(right, 1, cur);
  1332. #ifdef DEBUG
  1333. for (i = be16_to_cpu(right->bb_numrecs) - 1; i >= 0; i--) {
  1334. if ((error = xfs_btree_check_lptr_disk(cur, rpp[i], level))) {
  1335. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1336. return error;
  1337. }
  1338. }
  1339. #endif
  1340. memmove(rkp + 1, rkp, be16_to_cpu(right->bb_numrecs) * sizeof(*rkp));
  1341. memmove(rpp + 1, rpp, be16_to_cpu(right->bb_numrecs) * sizeof(*rpp));
  1342. #ifdef DEBUG
  1343. if ((error = xfs_btree_check_lptr_disk(cur, *lpp, level))) {
  1344. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1345. return error;
  1346. }
  1347. #endif
  1348. *rkp = *lkp;
  1349. *rpp = *lpp;
  1350. xfs_bmbt_log_keys(cur, rbp, 1, be16_to_cpu(right->bb_numrecs) + 1);
  1351. xfs_bmbt_log_ptrs(cur, rbp, 1, be16_to_cpu(right->bb_numrecs) + 1);
  1352. } else {
  1353. lrp = XFS_BMAP_REC_IADDR(left, be16_to_cpu(left->bb_numrecs), cur);
  1354. rrp = XFS_BMAP_REC_IADDR(right, 1, cur);
  1355. memmove(rrp + 1, rrp, be16_to_cpu(right->bb_numrecs) * sizeof(*rrp));
  1356. *rrp = *lrp;
  1357. xfs_bmbt_log_recs(cur, rbp, 1, be16_to_cpu(right->bb_numrecs) + 1);
  1358. key.br_startoff = cpu_to_be64(xfs_bmbt_disk_get_startoff(rrp));
  1359. rkp = &key;
  1360. }
  1361. be16_add(&left->bb_numrecs, -1);
  1362. xfs_bmbt_log_block(cur, lbp, XFS_BB_NUMRECS);
  1363. be16_add(&right->bb_numrecs, 1);
  1364. #ifdef DEBUG
  1365. if (level > 0)
  1366. xfs_btree_check_key(XFS_BTNUM_BMAP, rkp, rkp + 1);
  1367. else
  1368. xfs_btree_check_rec(XFS_BTNUM_BMAP, rrp, rrp + 1);
  1369. #endif
  1370. xfs_bmbt_log_block(cur, rbp, XFS_BB_NUMRECS);
  1371. if ((error = xfs_btree_dup_cursor(cur, &tcur))) {
  1372. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1373. return error;
  1374. }
  1375. i = xfs_btree_lastrec(tcur, level);
  1376. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  1377. if ((error = xfs_bmbt_increment(tcur, level, &i))) {
  1378. XFS_BMBT_TRACE_CURSOR(tcur, ERROR);
  1379. goto error1;
  1380. }
  1381. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  1382. if ((error = xfs_bmbt_updkey(tcur, rkp, level + 1))) {
  1383. XFS_BMBT_TRACE_CURSOR(tcur, ERROR);
  1384. goto error1;
  1385. }
  1386. xfs_btree_del_cursor(tcur, XFS_BTREE_NOERROR);
  1387. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1388. *stat = 1;
  1389. return 0;
  1390. error0:
  1391. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1392. error1:
  1393. xfs_btree_del_cursor(tcur, XFS_BTREE_ERROR);
  1394. return error;
  1395. }
  1396. /*
  1397. * Determine the extent state.
  1398. */
  1399. /* ARGSUSED */
  1400. STATIC xfs_exntst_t
  1401. xfs_extent_state(
  1402. xfs_filblks_t blks,
  1403. int extent_flag)
  1404. {
  1405. if (extent_flag) {
  1406. ASSERT(blks != 0); /* saved for DMIG */
  1407. return XFS_EXT_UNWRITTEN;
  1408. }
  1409. return XFS_EXT_NORM;
  1410. }
  1411. /*
  1412. * Split cur/level block in half.
  1413. * Return new block number and its first record (to be inserted into parent).
  1414. */
  1415. STATIC int /* error */
  1416. xfs_bmbt_split(
  1417. xfs_btree_cur_t *cur,
  1418. int level,
  1419. xfs_fsblock_t *bnop,
  1420. __uint64_t *startoff,
  1421. xfs_btree_cur_t **curp,
  1422. int *stat) /* success/failure */
  1423. {
  1424. xfs_alloc_arg_t args; /* block allocation args */
  1425. int error; /* error return value */
  1426. int i; /* loop counter */
  1427. xfs_fsblock_t lbno; /* left sibling block number */
  1428. xfs_buf_t *lbp; /* left buffer pointer */
  1429. xfs_bmbt_block_t *left; /* left btree block */
  1430. xfs_bmbt_key_t *lkp; /* left btree key */
  1431. xfs_bmbt_ptr_t *lpp; /* left address pointer */
  1432. xfs_bmbt_rec_t *lrp; /* left record pointer */
  1433. xfs_buf_t *rbp; /* right buffer pointer */
  1434. xfs_bmbt_block_t *right; /* right btree block */
  1435. xfs_bmbt_key_t *rkp; /* right btree key */
  1436. xfs_bmbt_ptr_t *rpp; /* right address pointer */
  1437. xfs_bmbt_block_t *rrblock; /* right-right btree block */
  1438. xfs_buf_t *rrbp; /* right-right buffer pointer */
  1439. xfs_bmbt_rec_t *rrp; /* right record pointer */
  1440. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1441. XFS_BMBT_TRACE_ARGIFK(cur, level, *bnop, *startoff);
  1442. args.tp = cur->bc_tp;
  1443. args.mp = cur->bc_mp;
  1444. lbp = cur->bc_bufs[level];
  1445. lbno = XFS_DADDR_TO_FSB(args.mp, XFS_BUF_ADDR(lbp));
  1446. left = XFS_BUF_TO_BMBT_BLOCK(lbp);
  1447. args.fsbno = cur->bc_private.b.firstblock;
  1448. args.firstblock = args.fsbno;
  1449. if (args.fsbno == NULLFSBLOCK) {
  1450. args.fsbno = lbno;
  1451. args.type = XFS_ALLOCTYPE_START_BNO;
  1452. } else
  1453. args.type = XFS_ALLOCTYPE_NEAR_BNO;
  1454. args.mod = args.minleft = args.alignment = args.total = args.isfl =
  1455. args.userdata = args.minalignslop = 0;
  1456. args.minlen = args.maxlen = args.prod = 1;
  1457. args.wasdel = cur->bc_private.b.flags & XFS_BTCUR_BPRV_WASDEL;
  1458. if (!args.wasdel && xfs_trans_get_block_res(args.tp) == 0) {
  1459. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1460. return XFS_ERROR(ENOSPC);
  1461. }
  1462. if ((error = xfs_alloc_vextent(&args))) {
  1463. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1464. return error;
  1465. }
  1466. if (args.fsbno == NULLFSBLOCK) {
  1467. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1468. *stat = 0;
  1469. return 0;
  1470. }
  1471. ASSERT(args.len == 1);
  1472. cur->bc_private.b.firstblock = args.fsbno;
  1473. cur->bc_private.b.allocated++;
  1474. cur->bc_private.b.ip->i_d.di_nblocks++;
  1475. xfs_trans_log_inode(args.tp, cur->bc_private.b.ip, XFS_ILOG_CORE);
  1476. XFS_TRANS_MOD_DQUOT_BYINO(args.mp, args.tp, cur->bc_private.b.ip,
  1477. XFS_TRANS_DQ_BCOUNT, 1L);
  1478. rbp = xfs_btree_get_bufl(args.mp, args.tp, args.fsbno, 0);
  1479. right = XFS_BUF_TO_BMBT_BLOCK(rbp);
  1480. #ifdef DEBUG
  1481. if ((error = xfs_btree_check_lblock(cur, left, level, rbp))) {
  1482. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1483. return error;
  1484. }
  1485. #endif
  1486. right->bb_magic = cpu_to_be32(XFS_BMAP_MAGIC);
  1487. right->bb_level = left->bb_level;
  1488. right->bb_numrecs = cpu_to_be16(be16_to_cpu(left->bb_numrecs) / 2);
  1489. if ((be16_to_cpu(left->bb_numrecs) & 1) &&
  1490. cur->bc_ptrs[level] <= be16_to_cpu(right->bb_numrecs) + 1)
  1491. be16_add(&right->bb_numrecs, 1);
  1492. i = be16_to_cpu(left->bb_numrecs) - be16_to_cpu(right->bb_numrecs) + 1;
  1493. if (level > 0) {
  1494. lkp = XFS_BMAP_KEY_IADDR(left, i, cur);
  1495. lpp = XFS_BMAP_PTR_IADDR(left, i, cur);
  1496. rkp = XFS_BMAP_KEY_IADDR(right, 1, cur);
  1497. rpp = XFS_BMAP_PTR_IADDR(right, 1, cur);
  1498. #ifdef DEBUG
  1499. for (i = 0; i < be16_to_cpu(right->bb_numrecs); i++) {
  1500. if ((error = xfs_btree_check_lptr_disk(cur, lpp[i], level))) {
  1501. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1502. return error;
  1503. }
  1504. }
  1505. #endif
  1506. memcpy(rkp, lkp, be16_to_cpu(right->bb_numrecs) * sizeof(*rkp));
  1507. memcpy(rpp, lpp, be16_to_cpu(right->bb_numrecs) * sizeof(*rpp));
  1508. xfs_bmbt_log_keys(cur, rbp, 1, be16_to_cpu(right->bb_numrecs));
  1509. xfs_bmbt_log_ptrs(cur, rbp, 1, be16_to_cpu(right->bb_numrecs));
  1510. *startoff = be64_to_cpu(rkp->br_startoff);
  1511. } else {
  1512. lrp = XFS_BMAP_REC_IADDR(left, i, cur);
  1513. rrp = XFS_BMAP_REC_IADDR(right, 1, cur);
  1514. memcpy(rrp, lrp, be16_to_cpu(right->bb_numrecs) * sizeof(*rrp));
  1515. xfs_bmbt_log_recs(cur, rbp, 1, be16_to_cpu(right->bb_numrecs));
  1516. *startoff = xfs_bmbt_disk_get_startoff(rrp);
  1517. }
  1518. be16_add(&left->bb_numrecs, -(be16_to_cpu(right->bb_numrecs)));
  1519. right->bb_rightsib = left->bb_rightsib;
  1520. left->bb_rightsib = cpu_to_be64(args.fsbno);
  1521. right->bb_leftsib = cpu_to_be64(lbno);
  1522. xfs_bmbt_log_block(cur, rbp, XFS_BB_ALL_BITS);
  1523. xfs_bmbt_log_block(cur, lbp, XFS_BB_NUMRECS | XFS_BB_RIGHTSIB);
  1524. if (be64_to_cpu(right->bb_rightsib) != NULLDFSBNO) {
  1525. if ((error = xfs_btree_read_bufl(args.mp, args.tp,
  1526. be64_to_cpu(right->bb_rightsib), 0, &rrbp,
  1527. XFS_BMAP_BTREE_REF))) {
  1528. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1529. return error;
  1530. }
  1531. rrblock = XFS_BUF_TO_BMBT_BLOCK(rrbp);
  1532. if ((error = xfs_btree_check_lblock(cur, rrblock, level, rrbp))) {
  1533. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1534. return error;
  1535. }
  1536. rrblock->bb_leftsib = cpu_to_be64(args.fsbno);
  1537. xfs_bmbt_log_block(cur, rrbp, XFS_BB_LEFTSIB);
  1538. }
  1539. if (cur->bc_ptrs[level] > be16_to_cpu(left->bb_numrecs) + 1) {
  1540. xfs_btree_setbuf(cur, level, rbp);
  1541. cur->bc_ptrs[level] -= be16_to_cpu(left->bb_numrecs);
  1542. }
  1543. if (level + 1 < cur->bc_nlevels) {
  1544. if ((error = xfs_btree_dup_cursor(cur, curp))) {
  1545. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1546. return error;
  1547. }
  1548. (*curp)->bc_ptrs[level + 1]++;
  1549. }
  1550. *bnop = args.fsbno;
  1551. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1552. *stat = 1;
  1553. return 0;
  1554. }
  1555. /*
  1556. * Update keys for the record.
  1557. */
  1558. STATIC int
  1559. xfs_bmbt_updkey(
  1560. xfs_btree_cur_t *cur,
  1561. xfs_bmbt_key_t *keyp, /* on-disk format */
  1562. int level)
  1563. {
  1564. xfs_bmbt_block_t *block;
  1565. xfs_buf_t *bp;
  1566. #ifdef DEBUG
  1567. int error;
  1568. #endif
  1569. xfs_bmbt_key_t *kp;
  1570. int ptr;
  1571. ASSERT(level >= 1);
  1572. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1573. XFS_BMBT_TRACE_ARGIK(cur, level, keyp);
  1574. for (ptr = 1; ptr == 1 && level < cur->bc_nlevels; level++) {
  1575. block = xfs_bmbt_get_block(cur, level, &bp);
  1576. #ifdef DEBUG
  1577. if ((error = xfs_btree_check_lblock(cur, block, level, bp))) {
  1578. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1579. return error;
  1580. }
  1581. #endif
  1582. ptr = cur->bc_ptrs[level];
  1583. kp = XFS_BMAP_KEY_IADDR(block, ptr, cur);
  1584. *kp = *keyp;
  1585. xfs_bmbt_log_keys(cur, bp, ptr, ptr);
  1586. }
  1587. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1588. return 0;
  1589. }
  1590. /*
  1591. * Convert on-disk form of btree root to in-memory form.
  1592. */
  1593. void
  1594. xfs_bmdr_to_bmbt(
  1595. xfs_bmdr_block_t *dblock,
  1596. int dblocklen,
  1597. xfs_bmbt_block_t *rblock,
  1598. int rblocklen)
  1599. {
  1600. int dmxr;
  1601. xfs_bmbt_key_t *fkp;
  1602. __be64 *fpp;
  1603. xfs_bmbt_key_t *tkp;
  1604. __be64 *tpp;
  1605. rblock->bb_magic = cpu_to_be32(XFS_BMAP_MAGIC);
  1606. rblock->bb_level = dblock->bb_level;
  1607. ASSERT(be16_to_cpu(rblock->bb_level) > 0);
  1608. rblock->bb_numrecs = dblock->bb_numrecs;
  1609. rblock->bb_leftsib = cpu_to_be64(NULLDFSBNO);
  1610. rblock->bb_rightsib = cpu_to_be64(NULLDFSBNO);
  1611. dmxr = (int)XFS_BTREE_BLOCK_MAXRECS(dblocklen, xfs_bmdr, 0);
  1612. fkp = XFS_BTREE_KEY_ADDR(xfs_bmdr, dblock, 1);
  1613. tkp = XFS_BMAP_BROOT_KEY_ADDR(rblock, 1, rblocklen);
  1614. fpp = XFS_BTREE_PTR_ADDR(xfs_bmdr, dblock, 1, dmxr);
  1615. tpp = XFS_BMAP_BROOT_PTR_ADDR(rblock, 1, rblocklen);
  1616. dmxr = be16_to_cpu(dblock->bb_numrecs);
  1617. memcpy(tkp, fkp, sizeof(*fkp) * dmxr);
  1618. memcpy(tpp, fpp, sizeof(*fpp) * dmxr);
  1619. }
  1620. /*
  1621. * Decrement cursor by one record at the level.
  1622. * For nonzero levels the leaf-ward information is untouched.
  1623. */
  1624. int /* error */
  1625. xfs_bmbt_decrement(
  1626. xfs_btree_cur_t *cur,
  1627. int level,
  1628. int *stat) /* success/failure */
  1629. {
  1630. xfs_bmbt_block_t *block;
  1631. xfs_buf_t *bp;
  1632. int error; /* error return value */
  1633. xfs_fsblock_t fsbno;
  1634. int lev;
  1635. xfs_mount_t *mp;
  1636. xfs_trans_t *tp;
  1637. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1638. XFS_BMBT_TRACE_ARGI(cur, level);
  1639. ASSERT(level < cur->bc_nlevels);
  1640. if (level < cur->bc_nlevels - 1)
  1641. xfs_btree_readahead(cur, level, XFS_BTCUR_LEFTRA);
  1642. if (--cur->bc_ptrs[level] > 0) {
  1643. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1644. *stat = 1;
  1645. return 0;
  1646. }
  1647. block = xfs_bmbt_get_block(cur, level, &bp);
  1648. #ifdef DEBUG
  1649. if ((error = xfs_btree_check_lblock(cur, block, level, bp))) {
  1650. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1651. return error;
  1652. }
  1653. #endif
  1654. if (be64_to_cpu(block->bb_leftsib) == NULLDFSBNO) {
  1655. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1656. *stat = 0;
  1657. return 0;
  1658. }
  1659. for (lev = level + 1; lev < cur->bc_nlevels; lev++) {
  1660. if (--cur->bc_ptrs[lev] > 0)
  1661. break;
  1662. if (lev < cur->bc_nlevels - 1)
  1663. xfs_btree_readahead(cur, lev, XFS_BTCUR_LEFTRA);
  1664. }
  1665. if (lev == cur->bc_nlevels) {
  1666. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1667. *stat = 0;
  1668. return 0;
  1669. }
  1670. tp = cur->bc_tp;
  1671. mp = cur->bc_mp;
  1672. for (block = xfs_bmbt_get_block(cur, lev, &bp); lev > level; ) {
  1673. fsbno = be64_to_cpu(*XFS_BMAP_PTR_IADDR(block, cur->bc_ptrs[lev], cur));
  1674. if ((error = xfs_btree_read_bufl(mp, tp, fsbno, 0, &bp,
  1675. XFS_BMAP_BTREE_REF))) {
  1676. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1677. return error;
  1678. }
  1679. lev--;
  1680. xfs_btree_setbuf(cur, lev, bp);
  1681. block = XFS_BUF_TO_BMBT_BLOCK(bp);
  1682. if ((error = xfs_btree_check_lblock(cur, block, lev, bp))) {
  1683. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1684. return error;
  1685. }
  1686. cur->bc_ptrs[lev] = be16_to_cpu(block->bb_numrecs);
  1687. }
  1688. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1689. *stat = 1;
  1690. return 0;
  1691. }
  1692. /*
  1693. * Delete the record pointed to by cur.
  1694. */
  1695. int /* error */
  1696. xfs_bmbt_delete(
  1697. xfs_btree_cur_t *cur,
  1698. int *stat) /* success/failure */
  1699. {
  1700. int error; /* error return value */
  1701. int i;
  1702. int level;
  1703. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1704. for (level = 0, i = 2; i == 2; level++) {
  1705. if ((error = xfs_bmbt_delrec(cur, level, &i))) {
  1706. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1707. return error;
  1708. }
  1709. }
  1710. if (i == 0) {
  1711. for (level = 1; level < cur->bc_nlevels; level++) {
  1712. if (cur->bc_ptrs[level] == 0) {
  1713. if ((error = xfs_bmbt_decrement(cur, level,
  1714. &i))) {
  1715. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1716. return error;
  1717. }
  1718. break;
  1719. }
  1720. }
  1721. }
  1722. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1723. *stat = i;
  1724. return 0;
  1725. }
  1726. /*
  1727. * Convert a compressed bmap extent record to an uncompressed form.
  1728. * This code must be in sync with the routines xfs_bmbt_get_startoff,
  1729. * xfs_bmbt_get_startblock, xfs_bmbt_get_blockcount and xfs_bmbt_get_state.
  1730. */
  1731. STATIC_INLINE void
  1732. __xfs_bmbt_get_all(
  1733. __uint64_t l0,
  1734. __uint64_t l1,
  1735. xfs_bmbt_irec_t *s)
  1736. {
  1737. int ext_flag;
  1738. xfs_exntst_t st;
  1739. ext_flag = (int)(l0 >> (64 - BMBT_EXNTFLAG_BITLEN));
  1740. s->br_startoff = ((xfs_fileoff_t)l0 &
  1741. XFS_MASK64LO(64 - BMBT_EXNTFLAG_BITLEN)) >> 9;
  1742. #if XFS_BIG_BLKNOS
  1743. s->br_startblock = (((xfs_fsblock_t)l0 & XFS_MASK64LO(9)) << 43) |
  1744. (((xfs_fsblock_t)l1) >> 21);
  1745. #else
  1746. #ifdef DEBUG
  1747. {
  1748. xfs_dfsbno_t b;
  1749. b = (((xfs_dfsbno_t)l0 & XFS_MASK64LO(9)) << 43) |
  1750. (((xfs_dfsbno_t)l1) >> 21);
  1751. ASSERT((b >> 32) == 0 || ISNULLDSTARTBLOCK(b));
  1752. s->br_startblock = (xfs_fsblock_t)b;
  1753. }
  1754. #else /* !DEBUG */
  1755. s->br_startblock = (xfs_fsblock_t)(((xfs_dfsbno_t)l1) >> 21);
  1756. #endif /* DEBUG */
  1757. #endif /* XFS_BIG_BLKNOS */
  1758. s->br_blockcount = (xfs_filblks_t)(l1 & XFS_MASK64LO(21));
  1759. /* This is xfs_extent_state() in-line */
  1760. if (ext_flag) {
  1761. ASSERT(s->br_blockcount != 0); /* saved for DMIG */
  1762. st = XFS_EXT_UNWRITTEN;
  1763. } else
  1764. st = XFS_EXT_NORM;
  1765. s->br_state = st;
  1766. }
  1767. void
  1768. xfs_bmbt_get_all(
  1769. xfs_bmbt_rec_host_t *r,
  1770. xfs_bmbt_irec_t *s)
  1771. {
  1772. __xfs_bmbt_get_all(r->l0, r->l1, s);
  1773. }
  1774. /*
  1775. * Get the block pointer for the given level of the cursor.
  1776. * Fill in the buffer pointer, if applicable.
  1777. */
  1778. xfs_bmbt_block_t *
  1779. xfs_bmbt_get_block(
  1780. xfs_btree_cur_t *cur,
  1781. int level,
  1782. xfs_buf_t **bpp)
  1783. {
  1784. xfs_ifork_t *ifp;
  1785. xfs_bmbt_block_t *rval;
  1786. if (level < cur->bc_nlevels - 1) {
  1787. *bpp = cur->bc_bufs[level];
  1788. rval = XFS_BUF_TO_BMBT_BLOCK(*bpp);
  1789. } else {
  1790. *bpp = NULL;
  1791. ifp = XFS_IFORK_PTR(cur->bc_private.b.ip,
  1792. cur->bc_private.b.whichfork);
  1793. rval = ifp->if_broot;
  1794. }
  1795. return rval;
  1796. }
  1797. /*
  1798. * Extract the blockcount field from an in memory bmap extent record.
  1799. */
  1800. xfs_filblks_t
  1801. xfs_bmbt_get_blockcount(
  1802. xfs_bmbt_rec_host_t *r)
  1803. {
  1804. return (xfs_filblks_t)(r->l1 & XFS_MASK64LO(21));
  1805. }
  1806. /*
  1807. * Extract the startblock field from an in memory bmap extent record.
  1808. */
  1809. xfs_fsblock_t
  1810. xfs_bmbt_get_startblock(
  1811. xfs_bmbt_rec_host_t *r)
  1812. {
  1813. #if XFS_BIG_BLKNOS
  1814. return (((xfs_fsblock_t)r->l0 & XFS_MASK64LO(9)) << 43) |
  1815. (((xfs_fsblock_t)r->l1) >> 21);
  1816. #else
  1817. #ifdef DEBUG
  1818. xfs_dfsbno_t b;
  1819. b = (((xfs_dfsbno_t)r->l0 & XFS_MASK64LO(9)) << 43) |
  1820. (((xfs_dfsbno_t)r->l1) >> 21);
  1821. ASSERT((b >> 32) == 0 || ISNULLDSTARTBLOCK(b));
  1822. return (xfs_fsblock_t)b;
  1823. #else /* !DEBUG */
  1824. return (xfs_fsblock_t)(((xfs_dfsbno_t)r->l1) >> 21);
  1825. #endif /* DEBUG */
  1826. #endif /* XFS_BIG_BLKNOS */
  1827. }
  1828. /*
  1829. * Extract the startoff field from an in memory bmap extent record.
  1830. */
  1831. xfs_fileoff_t
  1832. xfs_bmbt_get_startoff(
  1833. xfs_bmbt_rec_host_t *r)
  1834. {
  1835. return ((xfs_fileoff_t)r->l0 &
  1836. XFS_MASK64LO(64 - BMBT_EXNTFLAG_BITLEN)) >> 9;
  1837. }
  1838. xfs_exntst_t
  1839. xfs_bmbt_get_state(
  1840. xfs_bmbt_rec_host_t *r)
  1841. {
  1842. int ext_flag;
  1843. ext_flag = (int)((r->l0) >> (64 - BMBT_EXNTFLAG_BITLEN));
  1844. return xfs_extent_state(xfs_bmbt_get_blockcount(r),
  1845. ext_flag);
  1846. }
  1847. /* Endian flipping versions of the bmbt extraction functions */
  1848. void
  1849. xfs_bmbt_disk_get_all(
  1850. xfs_bmbt_rec_t *r,
  1851. xfs_bmbt_irec_t *s)
  1852. {
  1853. __xfs_bmbt_get_all(be64_to_cpu(r->l0), be64_to_cpu(r->l1), s);
  1854. }
  1855. /*
  1856. * Extract the blockcount field from an on disk bmap extent record.
  1857. */
  1858. xfs_filblks_t
  1859. xfs_bmbt_disk_get_blockcount(
  1860. xfs_bmbt_rec_t *r)
  1861. {
  1862. return (xfs_filblks_t)(be64_to_cpu(r->l1) & XFS_MASK64LO(21));
  1863. }
  1864. /*
  1865. * Extract the startoff field from a disk format bmap extent record.
  1866. */
  1867. xfs_fileoff_t
  1868. xfs_bmbt_disk_get_startoff(
  1869. xfs_bmbt_rec_t *r)
  1870. {
  1871. return ((xfs_fileoff_t)be64_to_cpu(r->l0) &
  1872. XFS_MASK64LO(64 - BMBT_EXNTFLAG_BITLEN)) >> 9;
  1873. }
  1874. /*
  1875. * Increment cursor by one record at the level.
  1876. * For nonzero levels the leaf-ward information is untouched.
  1877. */
  1878. int /* error */
  1879. xfs_bmbt_increment(
  1880. xfs_btree_cur_t *cur,
  1881. int level,
  1882. int *stat) /* success/failure */
  1883. {
  1884. xfs_bmbt_block_t *block;
  1885. xfs_buf_t *bp;
  1886. int error; /* error return value */
  1887. xfs_fsblock_t fsbno;
  1888. int lev;
  1889. xfs_mount_t *mp;
  1890. xfs_trans_t *tp;
  1891. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1892. XFS_BMBT_TRACE_ARGI(cur, level);
  1893. ASSERT(level < cur->bc_nlevels);
  1894. if (level < cur->bc_nlevels - 1)
  1895. xfs_btree_readahead(cur, level, XFS_BTCUR_RIGHTRA);
  1896. block = xfs_bmbt_get_block(cur, level, &bp);
  1897. #ifdef DEBUG
  1898. if ((error = xfs_btree_check_lblock(cur, block, level, bp))) {
  1899. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1900. return error;
  1901. }
  1902. #endif
  1903. if (++cur->bc_ptrs[level] <= be16_to_cpu(block->bb_numrecs)) {
  1904. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1905. *stat = 1;
  1906. return 0;
  1907. }
  1908. if (be64_to_cpu(block->bb_rightsib) == NULLDFSBNO) {
  1909. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1910. *stat = 0;
  1911. return 0;
  1912. }
  1913. for (lev = level + 1; lev < cur->bc_nlevels; lev++) {
  1914. block = xfs_bmbt_get_block(cur, lev, &bp);
  1915. #ifdef DEBUG
  1916. if ((error = xfs_btree_check_lblock(cur, block, lev, bp))) {
  1917. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1918. return error;
  1919. }
  1920. #endif
  1921. if (++cur->bc_ptrs[lev] <= be16_to_cpu(block->bb_numrecs))
  1922. break;
  1923. if (lev < cur->bc_nlevels - 1)
  1924. xfs_btree_readahead(cur, lev, XFS_BTCUR_RIGHTRA);
  1925. }
  1926. if (lev == cur->bc_nlevels) {
  1927. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1928. *stat = 0;
  1929. return 0;
  1930. }
  1931. tp = cur->bc_tp;
  1932. mp = cur->bc_mp;
  1933. for (block = xfs_bmbt_get_block(cur, lev, &bp); lev > level; ) {
  1934. fsbno = be64_to_cpu(*XFS_BMAP_PTR_IADDR(block, cur->bc_ptrs[lev], cur));
  1935. if ((error = xfs_btree_read_bufl(mp, tp, fsbno, 0, &bp,
  1936. XFS_BMAP_BTREE_REF))) {
  1937. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1938. return error;
  1939. }
  1940. lev--;
  1941. xfs_btree_setbuf(cur, lev, bp);
  1942. block = XFS_BUF_TO_BMBT_BLOCK(bp);
  1943. if ((error = xfs_btree_check_lblock(cur, block, lev, bp))) {
  1944. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1945. return error;
  1946. }
  1947. cur->bc_ptrs[lev] = 1;
  1948. }
  1949. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1950. *stat = 1;
  1951. return 0;
  1952. }
  1953. /*
  1954. * Insert the current record at the point referenced by cur.
  1955. */
  1956. int /* error */
  1957. xfs_bmbt_insert(
  1958. xfs_btree_cur_t *cur,
  1959. int *stat) /* success/failure */
  1960. {
  1961. int error; /* error return value */
  1962. int i;
  1963. int level;
  1964. xfs_fsblock_t nbno;
  1965. xfs_btree_cur_t *ncur;
  1966. xfs_bmbt_rec_t nrec;
  1967. xfs_btree_cur_t *pcur;
  1968. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1969. level = 0;
  1970. nbno = NULLFSBLOCK;
  1971. xfs_bmbt_disk_set_all(&nrec, &cur->bc_rec.b);
  1972. ncur = NULL;
  1973. pcur = cur;
  1974. do {
  1975. if ((error = xfs_bmbt_insrec(pcur, level++, &nbno, &nrec, &ncur,
  1976. &i))) {
  1977. if (pcur != cur)
  1978. xfs_btree_del_cursor(pcur, XFS_BTREE_ERROR);
  1979. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1980. return error;
  1981. }
  1982. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  1983. if (pcur != cur && (ncur || nbno == NULLFSBLOCK)) {
  1984. cur->bc_nlevels = pcur->bc_nlevels;
  1985. cur->bc_private.b.allocated +=
  1986. pcur->bc_private.b.allocated;
  1987. pcur->bc_private.b.allocated = 0;
  1988. ASSERT((cur->bc_private.b.firstblock != NULLFSBLOCK) ||
  1989. (cur->bc_private.b.ip->i_d.di_flags &
  1990. XFS_DIFLAG_REALTIME));
  1991. cur->bc_private.b.firstblock =
  1992. pcur->bc_private.b.firstblock;
  1993. ASSERT(cur->bc_private.b.flist ==
  1994. pcur->bc_private.b.flist);
  1995. xfs_btree_del_cursor(pcur, XFS_BTREE_NOERROR);
  1996. }
  1997. if (ncur) {
  1998. pcur = ncur;
  1999. ncur = NULL;
  2000. }
  2001. } while (nbno != NULLFSBLOCK);
  2002. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2003. *stat = i;
  2004. return 0;
  2005. error0:
  2006. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2007. return error;
  2008. }
  2009. /*
  2010. * Log fields from the btree block header.
  2011. */
  2012. void
  2013. xfs_bmbt_log_block(
  2014. xfs_btree_cur_t *cur,
  2015. xfs_buf_t *bp,
  2016. int fields)
  2017. {
  2018. int first;
  2019. int last;
  2020. xfs_trans_t *tp;
  2021. static const short offsets[] = {
  2022. offsetof(xfs_bmbt_block_t, bb_magic),
  2023. offsetof(xfs_bmbt_block_t, bb_level),
  2024. offsetof(xfs_bmbt_block_t, bb_numrecs),
  2025. offsetof(xfs_bmbt_block_t, bb_leftsib),
  2026. offsetof(xfs_bmbt_block_t, bb_rightsib),
  2027. sizeof(xfs_bmbt_block_t)
  2028. };
  2029. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  2030. XFS_BMBT_TRACE_ARGBI(cur, bp, fields);
  2031. tp = cur->bc_tp;
  2032. if (bp) {
  2033. xfs_btree_offsets(fields, offsets, XFS_BB_NUM_BITS, &first,
  2034. &last);
  2035. xfs_trans_log_buf(tp, bp, first, last);
  2036. } else
  2037. xfs_trans_log_inode(tp, cur->bc_private.b.ip,
  2038. XFS_ILOG_FBROOT(cur->bc_private.b.whichfork));
  2039. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2040. }
  2041. /*
  2042. * Log record values from the btree block.
  2043. */
  2044. void
  2045. xfs_bmbt_log_recs(
  2046. xfs_btree_cur_t *cur,
  2047. xfs_buf_t *bp,
  2048. int rfirst,
  2049. int rlast)
  2050. {
  2051. xfs_bmbt_block_t *block;
  2052. int first;
  2053. int last;
  2054. xfs_bmbt_rec_t *rp;
  2055. xfs_trans_t *tp;
  2056. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  2057. XFS_BMBT_TRACE_ARGBII(cur, bp, rfirst, rlast);
  2058. ASSERT(bp);
  2059. tp = cur->bc_tp;
  2060. block = XFS_BUF_TO_BMBT_BLOCK(bp);
  2061. rp = XFS_BMAP_REC_DADDR(block, 1, cur);
  2062. first = (int)((xfs_caddr_t)&rp[rfirst - 1] - (xfs_caddr_t)block);
  2063. last = (int)(((xfs_caddr_t)&rp[rlast] - 1) - (xfs_caddr_t)block);
  2064. xfs_trans_log_buf(tp, bp, first, last);
  2065. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2066. }
  2067. int /* error */
  2068. xfs_bmbt_lookup_eq(
  2069. xfs_btree_cur_t *cur,
  2070. xfs_fileoff_t off,
  2071. xfs_fsblock_t bno,
  2072. xfs_filblks_t len,
  2073. int *stat) /* success/failure */
  2074. {
  2075. cur->bc_rec.b.br_startoff = off;
  2076. cur->bc_rec.b.br_startblock = bno;
  2077. cur->bc_rec.b.br_blockcount = len;
  2078. return xfs_bmbt_lookup(cur, XFS_LOOKUP_EQ, stat);
  2079. }
  2080. int /* error */
  2081. xfs_bmbt_lookup_ge(
  2082. xfs_btree_cur_t *cur,
  2083. xfs_fileoff_t off,
  2084. xfs_fsblock_t bno,
  2085. xfs_filblks_t len,
  2086. int *stat) /* success/failure */
  2087. {
  2088. cur->bc_rec.b.br_startoff = off;
  2089. cur->bc_rec.b.br_startblock = bno;
  2090. cur->bc_rec.b.br_blockcount = len;
  2091. return xfs_bmbt_lookup(cur, XFS_LOOKUP_GE, stat);
  2092. }
  2093. /*
  2094. * Give the bmap btree a new root block. Copy the old broot contents
  2095. * down into a real block and make the broot point to it.
  2096. */
  2097. int /* error */
  2098. xfs_bmbt_newroot(
  2099. xfs_btree_cur_t *cur, /* btree cursor */
  2100. int *logflags, /* logging flags for inode */
  2101. int *stat) /* return status - 0 fail */
  2102. {
  2103. xfs_alloc_arg_t args; /* allocation arguments */
  2104. xfs_bmbt_block_t *block; /* bmap btree block */
  2105. xfs_buf_t *bp; /* buffer for block */
  2106. xfs_bmbt_block_t *cblock; /* child btree block */
  2107. xfs_bmbt_key_t *ckp; /* child key pointer */
  2108. xfs_bmbt_ptr_t *cpp; /* child ptr pointer */
  2109. int error; /* error return code */
  2110. #ifdef DEBUG
  2111. int i; /* loop counter */
  2112. #endif
  2113. xfs_bmbt_key_t *kp; /* pointer to bmap btree key */
  2114. int level; /* btree level */
  2115. xfs_bmbt_ptr_t *pp; /* pointer to bmap block addr */
  2116. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  2117. level = cur->bc_nlevels - 1;
  2118. block = xfs_bmbt_get_block(cur, level, &bp);
  2119. /*
  2120. * Copy the root into a real block.
  2121. */
  2122. args.mp = cur->bc_mp;
  2123. pp = XFS_BMAP_PTR_IADDR(block, 1, cur);
  2124. args.tp = cur->bc_tp;
  2125. args.fsbno = cur->bc_private.b.firstblock;
  2126. args.mod = args.minleft = args.alignment = args.total = args.isfl =
  2127. args.userdata = args.minalignslop = 0;
  2128. args.minlen = args.maxlen = args.prod = 1;
  2129. args.wasdel = cur->bc_private.b.flags & XFS_BTCUR_BPRV_WASDEL;
  2130. args.firstblock = args.fsbno;
  2131. if (args.fsbno == NULLFSBLOCK) {
  2132. #ifdef DEBUG
  2133. if ((error = xfs_btree_check_lptr_disk(cur, *pp, level))) {
  2134. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2135. return error;
  2136. }
  2137. #endif
  2138. args.fsbno = be64_to_cpu(*pp);
  2139. args.type = XFS_ALLOCTYPE_START_BNO;
  2140. } else
  2141. args.type = XFS_ALLOCTYPE_NEAR_BNO;
  2142. if ((error = xfs_alloc_vextent(&args))) {
  2143. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2144. return error;
  2145. }
  2146. if (args.fsbno == NULLFSBLOCK) {
  2147. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2148. *stat = 0;
  2149. return 0;
  2150. }
  2151. ASSERT(args.len == 1);
  2152. cur->bc_private.b.firstblock = args.fsbno;
  2153. cur->bc_private.b.allocated++;
  2154. cur->bc_private.b.ip->i_d.di_nblocks++;
  2155. XFS_TRANS_MOD_DQUOT_BYINO(args.mp, args.tp, cur->bc_private.b.ip,
  2156. XFS_TRANS_DQ_BCOUNT, 1L);
  2157. bp = xfs_btree_get_bufl(args.mp, cur->bc_tp, args.fsbno, 0);
  2158. cblock = XFS_BUF_TO_BMBT_BLOCK(bp);
  2159. *cblock = *block;
  2160. be16_add(&block->bb_level, 1);
  2161. block->bb_numrecs = cpu_to_be16(1);
  2162. cur->bc_nlevels++;
  2163. cur->bc_ptrs[level + 1] = 1;
  2164. kp = XFS_BMAP_KEY_IADDR(block, 1, cur);
  2165. ckp = XFS_BMAP_KEY_IADDR(cblock, 1, cur);
  2166. memcpy(ckp, kp, be16_to_cpu(cblock->bb_numrecs) * sizeof(*kp));
  2167. cpp = XFS_BMAP_PTR_IADDR(cblock, 1, cur);
  2168. #ifdef DEBUG
  2169. for (i = 0; i < be16_to_cpu(cblock->bb_numrecs); i++) {
  2170. if ((error = xfs_btree_check_lptr_disk(cur, pp[i], level))) {
  2171. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2172. return error;
  2173. }
  2174. }
  2175. #endif
  2176. memcpy(cpp, pp, be16_to_cpu(cblock->bb_numrecs) * sizeof(*pp));
  2177. #ifdef DEBUG
  2178. if ((error = xfs_btree_check_lptr(cur, args.fsbno, level))) {
  2179. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2180. return error;
  2181. }
  2182. #endif
  2183. *pp = cpu_to_be64(args.fsbno);
  2184. xfs_iroot_realloc(cur->bc_private.b.ip, 1 - be16_to_cpu(cblock->bb_numrecs),
  2185. cur->bc_private.b.whichfork);
  2186. xfs_btree_setbuf(cur, level, bp);
  2187. /*
  2188. * Do all this logging at the end so that
  2189. * the root is at the right level.
  2190. */
  2191. xfs_bmbt_log_block(cur, bp, XFS_BB_ALL_BITS);
  2192. xfs_bmbt_log_keys(cur, bp, 1, be16_to_cpu(cblock->bb_numrecs));
  2193. xfs_bmbt_log_ptrs(cur, bp, 1, be16_to_cpu(cblock->bb_numrecs));
  2194. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2195. *logflags |=
  2196. XFS_ILOG_CORE | XFS_ILOG_FBROOT(cur->bc_private.b.whichfork);
  2197. *stat = 1;
  2198. return 0;
  2199. }
  2200. /*
  2201. * Set all the fields in a bmap extent record from the arguments.
  2202. */
  2203. void
  2204. xfs_bmbt_set_allf(
  2205. xfs_bmbt_rec_host_t *r,
  2206. xfs_fileoff_t startoff,
  2207. xfs_fsblock_t startblock,
  2208. xfs_filblks_t blockcount,
  2209. xfs_exntst_t state)
  2210. {
  2211. int extent_flag = (state == XFS_EXT_NORM) ? 0 : 1;
  2212. ASSERT(state == XFS_EXT_NORM || state == XFS_EXT_UNWRITTEN);
  2213. ASSERT((startoff & XFS_MASK64HI(64-BMBT_STARTOFF_BITLEN)) == 0);
  2214. ASSERT((blockcount & XFS_MASK64HI(64-BMBT_BLOCKCOUNT_BITLEN)) == 0);
  2215. #if XFS_BIG_BLKNOS
  2216. ASSERT((startblock & XFS_MASK64HI(64-BMBT_STARTBLOCK_BITLEN)) == 0);
  2217. r->l0 = ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  2218. ((xfs_bmbt_rec_base_t)startoff << 9) |
  2219. ((xfs_bmbt_rec_base_t)startblock >> 43);
  2220. r->l1 = ((xfs_bmbt_rec_base_t)startblock << 21) |
  2221. ((xfs_bmbt_rec_base_t)blockcount &
  2222. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  2223. #else /* !XFS_BIG_BLKNOS */
  2224. if (ISNULLSTARTBLOCK(startblock)) {
  2225. r->l0 = ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  2226. ((xfs_bmbt_rec_base_t)startoff << 9) |
  2227. (xfs_bmbt_rec_base_t)XFS_MASK64LO(9);
  2228. r->l1 = XFS_MASK64HI(11) |
  2229. ((xfs_bmbt_rec_base_t)startblock << 21) |
  2230. ((xfs_bmbt_rec_base_t)blockcount &
  2231. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  2232. } else {
  2233. r->l0 = ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  2234. ((xfs_bmbt_rec_base_t)startoff << 9);
  2235. r->l1 = ((xfs_bmbt_rec_base_t)startblock << 21) |
  2236. ((xfs_bmbt_rec_base_t)blockcount &
  2237. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  2238. }
  2239. #endif /* XFS_BIG_BLKNOS */
  2240. }
  2241. /*
  2242. * Set all the fields in a bmap extent record from the uncompressed form.
  2243. */
  2244. void
  2245. xfs_bmbt_set_all(
  2246. xfs_bmbt_rec_host_t *r,
  2247. xfs_bmbt_irec_t *s)
  2248. {
  2249. xfs_bmbt_set_allf(r, s->br_startoff, s->br_startblock,
  2250. s->br_blockcount, s->br_state);
  2251. }
  2252. /*
  2253. * Set all the fields in a disk format bmap extent record from the arguments.
  2254. */
  2255. void
  2256. xfs_bmbt_disk_set_allf(
  2257. xfs_bmbt_rec_t *r,
  2258. xfs_fileoff_t startoff,
  2259. xfs_fsblock_t startblock,
  2260. xfs_filblks_t blockcount,
  2261. xfs_exntst_t state)
  2262. {
  2263. int extent_flag = (state == XFS_EXT_NORM) ? 0 : 1;
  2264. ASSERT(state == XFS_EXT_NORM || state == XFS_EXT_UNWRITTEN);
  2265. ASSERT((startoff & XFS_MASK64HI(64-BMBT_STARTOFF_BITLEN)) == 0);
  2266. ASSERT((blockcount & XFS_MASK64HI(64-BMBT_BLOCKCOUNT_BITLEN)) == 0);
  2267. #if XFS_BIG_BLKNOS
  2268. ASSERT((startblock & XFS_MASK64HI(64-BMBT_STARTBLOCK_BITLEN)) == 0);
  2269. r->l0 = cpu_to_be64(
  2270. ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  2271. ((xfs_bmbt_rec_base_t)startoff << 9) |
  2272. ((xfs_bmbt_rec_base_t)startblock >> 43));
  2273. r->l1 = cpu_to_be64(
  2274. ((xfs_bmbt_rec_base_t)startblock << 21) |
  2275. ((xfs_bmbt_rec_base_t)blockcount &
  2276. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21)));
  2277. #else /* !XFS_BIG_BLKNOS */
  2278. if (ISNULLSTARTBLOCK(startblock)) {
  2279. r->l0 = cpu_to_be64(
  2280. ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  2281. ((xfs_bmbt_rec_base_t)startoff << 9) |
  2282. (xfs_bmbt_rec_base_t)XFS_MASK64LO(9));
  2283. r->l1 = cpu_to_be64(XFS_MASK64HI(11) |
  2284. ((xfs_bmbt_rec_base_t)startblock << 21) |
  2285. ((xfs_bmbt_rec_base_t)blockcount &
  2286. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21)));
  2287. } else {
  2288. r->l0 = cpu_to_be64(
  2289. ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  2290. ((xfs_bmbt_rec_base_t)startoff << 9));
  2291. r->l1 = cpu_to_be64(
  2292. ((xfs_bmbt_rec_base_t)startblock << 21) |
  2293. ((xfs_bmbt_rec_base_t)blockcount &
  2294. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21)));
  2295. }
  2296. #endif /* XFS_BIG_BLKNOS */
  2297. }
  2298. /*
  2299. * Set all the fields in a bmap extent record from the uncompressed form.
  2300. */
  2301. void
  2302. xfs_bmbt_disk_set_all(
  2303. xfs_bmbt_rec_t *r,
  2304. xfs_bmbt_irec_t *s)
  2305. {
  2306. xfs_bmbt_disk_set_allf(r, s->br_startoff, s->br_startblock,
  2307. s->br_blockcount, s->br_state);
  2308. }
  2309. /*
  2310. * Set the blockcount field in a bmap extent record.
  2311. */
  2312. void
  2313. xfs_bmbt_set_blockcount(
  2314. xfs_bmbt_rec_host_t *r,
  2315. xfs_filblks_t v)
  2316. {
  2317. ASSERT((v & XFS_MASK64HI(43)) == 0);
  2318. r->l1 = (r->l1 & (xfs_bmbt_rec_base_t)XFS_MASK64HI(43)) |
  2319. (xfs_bmbt_rec_base_t)(v & XFS_MASK64LO(21));
  2320. }
  2321. /*
  2322. * Set the startblock field in a bmap extent record.
  2323. */
  2324. void
  2325. xfs_bmbt_set_startblock(
  2326. xfs_bmbt_rec_host_t *r,
  2327. xfs_fsblock_t v)
  2328. {
  2329. #if XFS_BIG_BLKNOS
  2330. ASSERT((v & XFS_MASK64HI(12)) == 0);
  2331. r->l0 = (r->l0 & (xfs_bmbt_rec_base_t)XFS_MASK64HI(55)) |
  2332. (xfs_bmbt_rec_base_t)(v >> 43);
  2333. r->l1 = (r->l1 & (xfs_bmbt_rec_base_t)XFS_MASK64LO(21)) |
  2334. (xfs_bmbt_rec_base_t)(v << 21);
  2335. #else /* !XFS_BIG_BLKNOS */
  2336. if (ISNULLSTARTBLOCK(v)) {
  2337. r->l0 |= (xfs_bmbt_rec_base_t)XFS_MASK64LO(9);
  2338. r->l1 = (xfs_bmbt_rec_base_t)XFS_MASK64HI(11) |
  2339. ((xfs_bmbt_rec_base_t)v << 21) |
  2340. (r->l1 & (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  2341. } else {
  2342. r->l0 &= ~(xfs_bmbt_rec_base_t)XFS_MASK64LO(9);
  2343. r->l1 = ((xfs_bmbt_rec_base_t)v << 21) |
  2344. (r->l1 & (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  2345. }
  2346. #endif /* XFS_BIG_BLKNOS */
  2347. }
  2348. /*
  2349. * Set the startoff field in a bmap extent record.
  2350. */
  2351. void
  2352. xfs_bmbt_set_startoff(
  2353. xfs_bmbt_rec_host_t *r,
  2354. xfs_fileoff_t v)
  2355. {
  2356. ASSERT((v & XFS_MASK64HI(9)) == 0);
  2357. r->l0 = (r->l0 & (xfs_bmbt_rec_base_t) XFS_MASK64HI(1)) |
  2358. ((xfs_bmbt_rec_base_t)v << 9) |
  2359. (r->l0 & (xfs_bmbt_rec_base_t)XFS_MASK64LO(9));
  2360. }
  2361. /*
  2362. * Set the extent state field in a bmap extent record.
  2363. */
  2364. void
  2365. xfs_bmbt_set_state(
  2366. xfs_bmbt_rec_host_t *r,
  2367. xfs_exntst_t v)
  2368. {
  2369. ASSERT(v == XFS_EXT_NORM || v == XFS_EXT_UNWRITTEN);
  2370. if (v == XFS_EXT_NORM)
  2371. r->l0 &= XFS_MASK64LO(64 - BMBT_EXNTFLAG_BITLEN);
  2372. else
  2373. r->l0 |= XFS_MASK64HI(BMBT_EXNTFLAG_BITLEN);
  2374. }
  2375. /*
  2376. * Convert in-memory form of btree root to on-disk form.
  2377. */
  2378. void
  2379. xfs_bmbt_to_bmdr(
  2380. xfs_bmbt_block_t *rblock,
  2381. int rblocklen,
  2382. xfs_bmdr_block_t *dblock,
  2383. int dblocklen)
  2384. {
  2385. int dmxr;
  2386. xfs_bmbt_key_t *fkp;
  2387. __be64 *fpp;
  2388. xfs_bmbt_key_t *tkp;
  2389. __be64 *tpp;
  2390. ASSERT(be32_to_cpu(rblock->bb_magic) == XFS_BMAP_MAGIC);
  2391. ASSERT(be64_to_cpu(rblock->bb_leftsib) == NULLDFSBNO);
  2392. ASSERT(be64_to_cpu(rblock->bb_rightsib) == NULLDFSBNO);
  2393. ASSERT(be16_to_cpu(rblock->bb_level) > 0);
  2394. dblock->bb_level = rblock->bb_level;
  2395. dblock->bb_numrecs = rblock->bb_numrecs;
  2396. dmxr = (int)XFS_BTREE_BLOCK_MAXRECS(dblocklen, xfs_bmdr, 0);
  2397. fkp = XFS_BMAP_BROOT_KEY_ADDR(rblock, 1, rblocklen);
  2398. tkp = XFS_BTREE_KEY_ADDR(xfs_bmdr, dblock, 1);
  2399. fpp = XFS_BMAP_BROOT_PTR_ADDR(rblock, 1, rblocklen);
  2400. tpp = XFS_BTREE_PTR_ADDR(xfs_bmdr, dblock, 1, dmxr);
  2401. dmxr = be16_to_cpu(dblock->bb_numrecs);
  2402. memcpy(tkp, fkp, sizeof(*fkp) * dmxr);
  2403. memcpy(tpp, fpp, sizeof(*fpp) * dmxr);
  2404. }
  2405. /*
  2406. * Update the record to the passed values.
  2407. */
  2408. int
  2409. xfs_bmbt_update(
  2410. xfs_btree_cur_t *cur,
  2411. xfs_fileoff_t off,
  2412. xfs_fsblock_t bno,
  2413. xfs_filblks_t len,
  2414. xfs_exntst_t state)
  2415. {
  2416. xfs_bmbt_block_t *block;
  2417. xfs_buf_t *bp;
  2418. int error;
  2419. xfs_bmbt_key_t key;
  2420. int ptr;
  2421. xfs_bmbt_rec_t *rp;
  2422. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  2423. XFS_BMBT_TRACE_ARGFFFI(cur, (xfs_dfiloff_t)off, (xfs_dfsbno_t)bno,
  2424. (xfs_dfilblks_t)len, (int)state);
  2425. block = xfs_bmbt_get_block(cur, 0, &bp);
  2426. #ifdef DEBUG
  2427. if ((error = xfs_btree_check_lblock(cur, block, 0, bp))) {
  2428. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2429. return error;
  2430. }
  2431. #endif
  2432. ptr = cur->bc_ptrs[0];
  2433. rp = XFS_BMAP_REC_IADDR(block, ptr, cur);
  2434. xfs_bmbt_disk_set_allf(rp, off, bno, len, state);
  2435. xfs_bmbt_log_recs(cur, bp, ptr, ptr);
  2436. if (ptr > 1) {
  2437. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2438. return 0;
  2439. }
  2440. key.br_startoff = cpu_to_be64(off);
  2441. if ((error = xfs_bmbt_updkey(cur, &key, 1))) {
  2442. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2443. return error;
  2444. }
  2445. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2446. return 0;
  2447. }
  2448. /*
  2449. * Check extent records, which have just been read, for
  2450. * any bit in the extent flag field. ASSERT on debug
  2451. * kernels, as this condition should not occur.
  2452. * Return an error condition (1) if any flags found,
  2453. * otherwise return 0.
  2454. */
  2455. int
  2456. xfs_check_nostate_extents(
  2457. xfs_ifork_t *ifp,
  2458. xfs_extnum_t idx,
  2459. xfs_extnum_t num)
  2460. {
  2461. for (; num > 0; num--, idx++) {
  2462. xfs_bmbt_rec_host_t *ep = xfs_iext_get_ext(ifp, idx);
  2463. if ((ep->l0 >>
  2464. (64 - BMBT_EXNTFLAG_BITLEN)) != 0) {
  2465. ASSERT(0);
  2466. return 1;
  2467. }
  2468. }
  2469. return 0;
  2470. }