xfs_bmap_btree.c 70 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591
  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(__func__, c, b, i, __LINE__)
  259. #define XFS_BMBT_TRACE_ARGBII(c,b,i,j) \
  260. xfs_bmbt_trace_argbii(__func__, c, b, i, j, __LINE__)
  261. #define XFS_BMBT_TRACE_ARGFFFI(c,o,b,i,j) \
  262. xfs_bmbt_trace_argfffi(__func__, c, o, b, i, j, __LINE__)
  263. #define XFS_BMBT_TRACE_ARGI(c,i) \
  264. xfs_bmbt_trace_argi(__func__, c, i, __LINE__)
  265. #define XFS_BMBT_TRACE_ARGIFK(c,i,f,s) \
  266. xfs_bmbt_trace_argifk(__func__, c, i, f, s, __LINE__)
  267. #define XFS_BMBT_TRACE_ARGIFR(c,i,f,r) \
  268. xfs_bmbt_trace_argifr(__func__, c, i, f, r, __LINE__)
  269. #define XFS_BMBT_TRACE_ARGIK(c,i,k) \
  270. xfs_bmbt_trace_argik(__func__, c, i, k, __LINE__)
  271. #define XFS_BMBT_TRACE_CURSOR(c,s) \
  272. xfs_bmbt_trace_cursor(__func__, 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_cpu(&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_cpu(&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_cpu(&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_cpu(&left->bb_numrecs, -1);
  1362. xfs_bmbt_log_block(cur, lbp, XFS_BB_NUMRECS);
  1363. be16_add_cpu(&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. args.minleft = 0;
  1450. if (args.fsbno == NULLFSBLOCK) {
  1451. args.fsbno = lbno;
  1452. args.type = XFS_ALLOCTYPE_START_BNO;
  1453. /*
  1454. * Make sure there is sufficient room left in the AG to
  1455. * complete a full tree split for an extent insert. If
  1456. * we are converting the middle part of an extent then
  1457. * we may need space for two tree splits.
  1458. *
  1459. * We are relying on the caller to make the correct block
  1460. * reservation for this operation to succeed. If the
  1461. * reservation amount is insufficient then we may fail a
  1462. * block allocation here and corrupt the filesystem.
  1463. */
  1464. args.minleft = xfs_trans_get_block_res(args.tp);
  1465. } else
  1466. args.type = XFS_ALLOCTYPE_NEAR_BNO;
  1467. args.mod = args.alignment = args.total = args.isfl =
  1468. args.userdata = args.minalignslop = 0;
  1469. args.minlen = args.maxlen = args.prod = 1;
  1470. args.wasdel = cur->bc_private.b.flags & XFS_BTCUR_BPRV_WASDEL;
  1471. if (!args.wasdel && xfs_trans_get_block_res(args.tp) == 0) {
  1472. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1473. return XFS_ERROR(ENOSPC);
  1474. }
  1475. if ((error = xfs_alloc_vextent(&args))) {
  1476. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1477. return error;
  1478. }
  1479. if (args.fsbno == NULLFSBLOCK) {
  1480. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1481. *stat = 0;
  1482. return 0;
  1483. }
  1484. ASSERT(args.len == 1);
  1485. cur->bc_private.b.firstblock = args.fsbno;
  1486. cur->bc_private.b.allocated++;
  1487. cur->bc_private.b.ip->i_d.di_nblocks++;
  1488. xfs_trans_log_inode(args.tp, cur->bc_private.b.ip, XFS_ILOG_CORE);
  1489. XFS_TRANS_MOD_DQUOT_BYINO(args.mp, args.tp, cur->bc_private.b.ip,
  1490. XFS_TRANS_DQ_BCOUNT, 1L);
  1491. rbp = xfs_btree_get_bufl(args.mp, args.tp, args.fsbno, 0);
  1492. right = XFS_BUF_TO_BMBT_BLOCK(rbp);
  1493. #ifdef DEBUG
  1494. if ((error = xfs_btree_check_lblock(cur, left, level, rbp))) {
  1495. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1496. return error;
  1497. }
  1498. #endif
  1499. right->bb_magic = cpu_to_be32(XFS_BMAP_MAGIC);
  1500. right->bb_level = left->bb_level;
  1501. right->bb_numrecs = cpu_to_be16(be16_to_cpu(left->bb_numrecs) / 2);
  1502. if ((be16_to_cpu(left->bb_numrecs) & 1) &&
  1503. cur->bc_ptrs[level] <= be16_to_cpu(right->bb_numrecs) + 1)
  1504. be16_add_cpu(&right->bb_numrecs, 1);
  1505. i = be16_to_cpu(left->bb_numrecs) - be16_to_cpu(right->bb_numrecs) + 1;
  1506. if (level > 0) {
  1507. lkp = XFS_BMAP_KEY_IADDR(left, i, cur);
  1508. lpp = XFS_BMAP_PTR_IADDR(left, i, cur);
  1509. rkp = XFS_BMAP_KEY_IADDR(right, 1, cur);
  1510. rpp = XFS_BMAP_PTR_IADDR(right, 1, cur);
  1511. #ifdef DEBUG
  1512. for (i = 0; i < be16_to_cpu(right->bb_numrecs); i++) {
  1513. if ((error = xfs_btree_check_lptr_disk(cur, lpp[i], level))) {
  1514. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1515. return error;
  1516. }
  1517. }
  1518. #endif
  1519. memcpy(rkp, lkp, be16_to_cpu(right->bb_numrecs) * sizeof(*rkp));
  1520. memcpy(rpp, lpp, be16_to_cpu(right->bb_numrecs) * sizeof(*rpp));
  1521. xfs_bmbt_log_keys(cur, rbp, 1, be16_to_cpu(right->bb_numrecs));
  1522. xfs_bmbt_log_ptrs(cur, rbp, 1, be16_to_cpu(right->bb_numrecs));
  1523. *startoff = be64_to_cpu(rkp->br_startoff);
  1524. } else {
  1525. lrp = XFS_BMAP_REC_IADDR(left, i, cur);
  1526. rrp = XFS_BMAP_REC_IADDR(right, 1, cur);
  1527. memcpy(rrp, lrp, be16_to_cpu(right->bb_numrecs) * sizeof(*rrp));
  1528. xfs_bmbt_log_recs(cur, rbp, 1, be16_to_cpu(right->bb_numrecs));
  1529. *startoff = xfs_bmbt_disk_get_startoff(rrp);
  1530. }
  1531. be16_add_cpu(&left->bb_numrecs, -(be16_to_cpu(right->bb_numrecs)));
  1532. right->bb_rightsib = left->bb_rightsib;
  1533. left->bb_rightsib = cpu_to_be64(args.fsbno);
  1534. right->bb_leftsib = cpu_to_be64(lbno);
  1535. xfs_bmbt_log_block(cur, rbp, XFS_BB_ALL_BITS);
  1536. xfs_bmbt_log_block(cur, lbp, XFS_BB_NUMRECS | XFS_BB_RIGHTSIB);
  1537. if (be64_to_cpu(right->bb_rightsib) != NULLDFSBNO) {
  1538. if ((error = xfs_btree_read_bufl(args.mp, args.tp,
  1539. be64_to_cpu(right->bb_rightsib), 0, &rrbp,
  1540. XFS_BMAP_BTREE_REF))) {
  1541. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1542. return error;
  1543. }
  1544. rrblock = XFS_BUF_TO_BMBT_BLOCK(rrbp);
  1545. if ((error = xfs_btree_check_lblock(cur, rrblock, level, rrbp))) {
  1546. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1547. return error;
  1548. }
  1549. rrblock->bb_leftsib = cpu_to_be64(args.fsbno);
  1550. xfs_bmbt_log_block(cur, rrbp, XFS_BB_LEFTSIB);
  1551. }
  1552. if (cur->bc_ptrs[level] > be16_to_cpu(left->bb_numrecs) + 1) {
  1553. xfs_btree_setbuf(cur, level, rbp);
  1554. cur->bc_ptrs[level] -= be16_to_cpu(left->bb_numrecs);
  1555. }
  1556. if (level + 1 < cur->bc_nlevels) {
  1557. if ((error = xfs_btree_dup_cursor(cur, curp))) {
  1558. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1559. return error;
  1560. }
  1561. (*curp)->bc_ptrs[level + 1]++;
  1562. }
  1563. *bnop = args.fsbno;
  1564. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1565. *stat = 1;
  1566. return 0;
  1567. }
  1568. /*
  1569. * Update keys for the record.
  1570. */
  1571. STATIC int
  1572. xfs_bmbt_updkey(
  1573. xfs_btree_cur_t *cur,
  1574. xfs_bmbt_key_t *keyp, /* on-disk format */
  1575. int level)
  1576. {
  1577. xfs_bmbt_block_t *block;
  1578. xfs_buf_t *bp;
  1579. #ifdef DEBUG
  1580. int error;
  1581. #endif
  1582. xfs_bmbt_key_t *kp;
  1583. int ptr;
  1584. ASSERT(level >= 1);
  1585. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1586. XFS_BMBT_TRACE_ARGIK(cur, level, keyp);
  1587. for (ptr = 1; ptr == 1 && level < cur->bc_nlevels; level++) {
  1588. block = xfs_bmbt_get_block(cur, level, &bp);
  1589. #ifdef DEBUG
  1590. if ((error = xfs_btree_check_lblock(cur, block, level, bp))) {
  1591. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1592. return error;
  1593. }
  1594. #endif
  1595. ptr = cur->bc_ptrs[level];
  1596. kp = XFS_BMAP_KEY_IADDR(block, ptr, cur);
  1597. *kp = *keyp;
  1598. xfs_bmbt_log_keys(cur, bp, ptr, ptr);
  1599. }
  1600. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1601. return 0;
  1602. }
  1603. /*
  1604. * Convert on-disk form of btree root to in-memory form.
  1605. */
  1606. void
  1607. xfs_bmdr_to_bmbt(
  1608. xfs_bmdr_block_t *dblock,
  1609. int dblocklen,
  1610. xfs_bmbt_block_t *rblock,
  1611. int rblocklen)
  1612. {
  1613. int dmxr;
  1614. xfs_bmbt_key_t *fkp;
  1615. __be64 *fpp;
  1616. xfs_bmbt_key_t *tkp;
  1617. __be64 *tpp;
  1618. rblock->bb_magic = cpu_to_be32(XFS_BMAP_MAGIC);
  1619. rblock->bb_level = dblock->bb_level;
  1620. ASSERT(be16_to_cpu(rblock->bb_level) > 0);
  1621. rblock->bb_numrecs = dblock->bb_numrecs;
  1622. rblock->bb_leftsib = cpu_to_be64(NULLDFSBNO);
  1623. rblock->bb_rightsib = cpu_to_be64(NULLDFSBNO);
  1624. dmxr = (int)XFS_BTREE_BLOCK_MAXRECS(dblocklen, xfs_bmdr, 0);
  1625. fkp = XFS_BTREE_KEY_ADDR(xfs_bmdr, dblock, 1);
  1626. tkp = XFS_BMAP_BROOT_KEY_ADDR(rblock, 1, rblocklen);
  1627. fpp = XFS_BTREE_PTR_ADDR(xfs_bmdr, dblock, 1, dmxr);
  1628. tpp = XFS_BMAP_BROOT_PTR_ADDR(rblock, 1, rblocklen);
  1629. dmxr = be16_to_cpu(dblock->bb_numrecs);
  1630. memcpy(tkp, fkp, sizeof(*fkp) * dmxr);
  1631. memcpy(tpp, fpp, sizeof(*fpp) * dmxr);
  1632. }
  1633. /*
  1634. * Decrement cursor by one record at the level.
  1635. * For nonzero levels the leaf-ward information is untouched.
  1636. */
  1637. int /* error */
  1638. xfs_bmbt_decrement(
  1639. xfs_btree_cur_t *cur,
  1640. int level,
  1641. int *stat) /* success/failure */
  1642. {
  1643. xfs_bmbt_block_t *block;
  1644. xfs_buf_t *bp;
  1645. int error; /* error return value */
  1646. xfs_fsblock_t fsbno;
  1647. int lev;
  1648. xfs_mount_t *mp;
  1649. xfs_trans_t *tp;
  1650. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1651. XFS_BMBT_TRACE_ARGI(cur, level);
  1652. ASSERT(level < cur->bc_nlevels);
  1653. if (level < cur->bc_nlevels - 1)
  1654. xfs_btree_readahead(cur, level, XFS_BTCUR_LEFTRA);
  1655. if (--cur->bc_ptrs[level] > 0) {
  1656. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1657. *stat = 1;
  1658. return 0;
  1659. }
  1660. block = xfs_bmbt_get_block(cur, level, &bp);
  1661. #ifdef DEBUG
  1662. if ((error = xfs_btree_check_lblock(cur, block, level, bp))) {
  1663. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1664. return error;
  1665. }
  1666. #endif
  1667. if (be64_to_cpu(block->bb_leftsib) == NULLDFSBNO) {
  1668. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1669. *stat = 0;
  1670. return 0;
  1671. }
  1672. for (lev = level + 1; lev < cur->bc_nlevels; lev++) {
  1673. if (--cur->bc_ptrs[lev] > 0)
  1674. break;
  1675. if (lev < cur->bc_nlevels - 1)
  1676. xfs_btree_readahead(cur, lev, XFS_BTCUR_LEFTRA);
  1677. }
  1678. if (lev == cur->bc_nlevels) {
  1679. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1680. *stat = 0;
  1681. return 0;
  1682. }
  1683. tp = cur->bc_tp;
  1684. mp = cur->bc_mp;
  1685. for (block = xfs_bmbt_get_block(cur, lev, &bp); lev > level; ) {
  1686. fsbno = be64_to_cpu(*XFS_BMAP_PTR_IADDR(block, cur->bc_ptrs[lev], cur));
  1687. if ((error = xfs_btree_read_bufl(mp, tp, fsbno, 0, &bp,
  1688. XFS_BMAP_BTREE_REF))) {
  1689. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1690. return error;
  1691. }
  1692. lev--;
  1693. xfs_btree_setbuf(cur, lev, bp);
  1694. block = XFS_BUF_TO_BMBT_BLOCK(bp);
  1695. if ((error = xfs_btree_check_lblock(cur, block, lev, bp))) {
  1696. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1697. return error;
  1698. }
  1699. cur->bc_ptrs[lev] = be16_to_cpu(block->bb_numrecs);
  1700. }
  1701. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1702. *stat = 1;
  1703. return 0;
  1704. }
  1705. /*
  1706. * Delete the record pointed to by cur.
  1707. */
  1708. int /* error */
  1709. xfs_bmbt_delete(
  1710. xfs_btree_cur_t *cur,
  1711. int *stat) /* success/failure */
  1712. {
  1713. int error; /* error return value */
  1714. int i;
  1715. int level;
  1716. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1717. for (level = 0, i = 2; i == 2; level++) {
  1718. if ((error = xfs_bmbt_delrec(cur, level, &i))) {
  1719. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1720. return error;
  1721. }
  1722. }
  1723. if (i == 0) {
  1724. for (level = 1; level < cur->bc_nlevels; level++) {
  1725. if (cur->bc_ptrs[level] == 0) {
  1726. if ((error = xfs_bmbt_decrement(cur, level,
  1727. &i))) {
  1728. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1729. return error;
  1730. }
  1731. break;
  1732. }
  1733. }
  1734. }
  1735. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1736. *stat = i;
  1737. return 0;
  1738. }
  1739. /*
  1740. * Convert a compressed bmap extent record to an uncompressed form.
  1741. * This code must be in sync with the routines xfs_bmbt_get_startoff,
  1742. * xfs_bmbt_get_startblock, xfs_bmbt_get_blockcount and xfs_bmbt_get_state.
  1743. */
  1744. STATIC_INLINE void
  1745. __xfs_bmbt_get_all(
  1746. __uint64_t l0,
  1747. __uint64_t l1,
  1748. xfs_bmbt_irec_t *s)
  1749. {
  1750. int ext_flag;
  1751. xfs_exntst_t st;
  1752. ext_flag = (int)(l0 >> (64 - BMBT_EXNTFLAG_BITLEN));
  1753. s->br_startoff = ((xfs_fileoff_t)l0 &
  1754. XFS_MASK64LO(64 - BMBT_EXNTFLAG_BITLEN)) >> 9;
  1755. #if XFS_BIG_BLKNOS
  1756. s->br_startblock = (((xfs_fsblock_t)l0 & XFS_MASK64LO(9)) << 43) |
  1757. (((xfs_fsblock_t)l1) >> 21);
  1758. #else
  1759. #ifdef DEBUG
  1760. {
  1761. xfs_dfsbno_t b;
  1762. b = (((xfs_dfsbno_t)l0 & XFS_MASK64LO(9)) << 43) |
  1763. (((xfs_dfsbno_t)l1) >> 21);
  1764. ASSERT((b >> 32) == 0 || ISNULLDSTARTBLOCK(b));
  1765. s->br_startblock = (xfs_fsblock_t)b;
  1766. }
  1767. #else /* !DEBUG */
  1768. s->br_startblock = (xfs_fsblock_t)(((xfs_dfsbno_t)l1) >> 21);
  1769. #endif /* DEBUG */
  1770. #endif /* XFS_BIG_BLKNOS */
  1771. s->br_blockcount = (xfs_filblks_t)(l1 & XFS_MASK64LO(21));
  1772. /* This is xfs_extent_state() in-line */
  1773. if (ext_flag) {
  1774. ASSERT(s->br_blockcount != 0); /* saved for DMIG */
  1775. st = XFS_EXT_UNWRITTEN;
  1776. } else
  1777. st = XFS_EXT_NORM;
  1778. s->br_state = st;
  1779. }
  1780. void
  1781. xfs_bmbt_get_all(
  1782. xfs_bmbt_rec_host_t *r,
  1783. xfs_bmbt_irec_t *s)
  1784. {
  1785. __xfs_bmbt_get_all(r->l0, r->l1, s);
  1786. }
  1787. /*
  1788. * Get the block pointer for the given level of the cursor.
  1789. * Fill in the buffer pointer, if applicable.
  1790. */
  1791. xfs_bmbt_block_t *
  1792. xfs_bmbt_get_block(
  1793. xfs_btree_cur_t *cur,
  1794. int level,
  1795. xfs_buf_t **bpp)
  1796. {
  1797. xfs_ifork_t *ifp;
  1798. xfs_bmbt_block_t *rval;
  1799. if (level < cur->bc_nlevels - 1) {
  1800. *bpp = cur->bc_bufs[level];
  1801. rval = XFS_BUF_TO_BMBT_BLOCK(*bpp);
  1802. } else {
  1803. *bpp = NULL;
  1804. ifp = XFS_IFORK_PTR(cur->bc_private.b.ip,
  1805. cur->bc_private.b.whichfork);
  1806. rval = ifp->if_broot;
  1807. }
  1808. return rval;
  1809. }
  1810. /*
  1811. * Extract the blockcount field from an in memory bmap extent record.
  1812. */
  1813. xfs_filblks_t
  1814. xfs_bmbt_get_blockcount(
  1815. xfs_bmbt_rec_host_t *r)
  1816. {
  1817. return (xfs_filblks_t)(r->l1 & XFS_MASK64LO(21));
  1818. }
  1819. /*
  1820. * Extract the startblock field from an in memory bmap extent record.
  1821. */
  1822. xfs_fsblock_t
  1823. xfs_bmbt_get_startblock(
  1824. xfs_bmbt_rec_host_t *r)
  1825. {
  1826. #if XFS_BIG_BLKNOS
  1827. return (((xfs_fsblock_t)r->l0 & XFS_MASK64LO(9)) << 43) |
  1828. (((xfs_fsblock_t)r->l1) >> 21);
  1829. #else
  1830. #ifdef DEBUG
  1831. xfs_dfsbno_t b;
  1832. b = (((xfs_dfsbno_t)r->l0 & XFS_MASK64LO(9)) << 43) |
  1833. (((xfs_dfsbno_t)r->l1) >> 21);
  1834. ASSERT((b >> 32) == 0 || ISNULLDSTARTBLOCK(b));
  1835. return (xfs_fsblock_t)b;
  1836. #else /* !DEBUG */
  1837. return (xfs_fsblock_t)(((xfs_dfsbno_t)r->l1) >> 21);
  1838. #endif /* DEBUG */
  1839. #endif /* XFS_BIG_BLKNOS */
  1840. }
  1841. /*
  1842. * Extract the startoff field from an in memory bmap extent record.
  1843. */
  1844. xfs_fileoff_t
  1845. xfs_bmbt_get_startoff(
  1846. xfs_bmbt_rec_host_t *r)
  1847. {
  1848. return ((xfs_fileoff_t)r->l0 &
  1849. XFS_MASK64LO(64 - BMBT_EXNTFLAG_BITLEN)) >> 9;
  1850. }
  1851. xfs_exntst_t
  1852. xfs_bmbt_get_state(
  1853. xfs_bmbt_rec_host_t *r)
  1854. {
  1855. int ext_flag;
  1856. ext_flag = (int)((r->l0) >> (64 - BMBT_EXNTFLAG_BITLEN));
  1857. return xfs_extent_state(xfs_bmbt_get_blockcount(r),
  1858. ext_flag);
  1859. }
  1860. /* Endian flipping versions of the bmbt extraction functions */
  1861. void
  1862. xfs_bmbt_disk_get_all(
  1863. xfs_bmbt_rec_t *r,
  1864. xfs_bmbt_irec_t *s)
  1865. {
  1866. __xfs_bmbt_get_all(be64_to_cpu(r->l0), be64_to_cpu(r->l1), s);
  1867. }
  1868. /*
  1869. * Extract the blockcount field from an on disk bmap extent record.
  1870. */
  1871. xfs_filblks_t
  1872. xfs_bmbt_disk_get_blockcount(
  1873. xfs_bmbt_rec_t *r)
  1874. {
  1875. return (xfs_filblks_t)(be64_to_cpu(r->l1) & XFS_MASK64LO(21));
  1876. }
  1877. /*
  1878. * Extract the startoff field from a disk format bmap extent record.
  1879. */
  1880. xfs_fileoff_t
  1881. xfs_bmbt_disk_get_startoff(
  1882. xfs_bmbt_rec_t *r)
  1883. {
  1884. return ((xfs_fileoff_t)be64_to_cpu(r->l0) &
  1885. XFS_MASK64LO(64 - BMBT_EXNTFLAG_BITLEN)) >> 9;
  1886. }
  1887. /*
  1888. * Increment cursor by one record at the level.
  1889. * For nonzero levels the leaf-ward information is untouched.
  1890. */
  1891. int /* error */
  1892. xfs_bmbt_increment(
  1893. xfs_btree_cur_t *cur,
  1894. int level,
  1895. int *stat) /* success/failure */
  1896. {
  1897. xfs_bmbt_block_t *block;
  1898. xfs_buf_t *bp;
  1899. int error; /* error return value */
  1900. xfs_fsblock_t fsbno;
  1901. int lev;
  1902. xfs_mount_t *mp;
  1903. xfs_trans_t *tp;
  1904. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1905. XFS_BMBT_TRACE_ARGI(cur, level);
  1906. ASSERT(level < cur->bc_nlevels);
  1907. if (level < cur->bc_nlevels - 1)
  1908. xfs_btree_readahead(cur, level, XFS_BTCUR_RIGHTRA);
  1909. block = xfs_bmbt_get_block(cur, level, &bp);
  1910. #ifdef DEBUG
  1911. if ((error = xfs_btree_check_lblock(cur, block, level, bp))) {
  1912. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1913. return error;
  1914. }
  1915. #endif
  1916. if (++cur->bc_ptrs[level] <= be16_to_cpu(block->bb_numrecs)) {
  1917. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1918. *stat = 1;
  1919. return 0;
  1920. }
  1921. if (be64_to_cpu(block->bb_rightsib) == NULLDFSBNO) {
  1922. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1923. *stat = 0;
  1924. return 0;
  1925. }
  1926. for (lev = level + 1; lev < cur->bc_nlevels; lev++) {
  1927. block = xfs_bmbt_get_block(cur, lev, &bp);
  1928. #ifdef DEBUG
  1929. if ((error = xfs_btree_check_lblock(cur, block, lev, bp))) {
  1930. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1931. return error;
  1932. }
  1933. #endif
  1934. if (++cur->bc_ptrs[lev] <= be16_to_cpu(block->bb_numrecs))
  1935. break;
  1936. if (lev < cur->bc_nlevels - 1)
  1937. xfs_btree_readahead(cur, lev, XFS_BTCUR_RIGHTRA);
  1938. }
  1939. if (lev == cur->bc_nlevels) {
  1940. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1941. *stat = 0;
  1942. return 0;
  1943. }
  1944. tp = cur->bc_tp;
  1945. mp = cur->bc_mp;
  1946. for (block = xfs_bmbt_get_block(cur, lev, &bp); lev > level; ) {
  1947. fsbno = be64_to_cpu(*XFS_BMAP_PTR_IADDR(block, cur->bc_ptrs[lev], cur));
  1948. if ((error = xfs_btree_read_bufl(mp, tp, fsbno, 0, &bp,
  1949. XFS_BMAP_BTREE_REF))) {
  1950. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1951. return error;
  1952. }
  1953. lev--;
  1954. xfs_btree_setbuf(cur, lev, bp);
  1955. block = XFS_BUF_TO_BMBT_BLOCK(bp);
  1956. if ((error = xfs_btree_check_lblock(cur, block, lev, bp))) {
  1957. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1958. return error;
  1959. }
  1960. cur->bc_ptrs[lev] = 1;
  1961. }
  1962. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  1963. *stat = 1;
  1964. return 0;
  1965. }
  1966. /*
  1967. * Insert the current record at the point referenced by cur.
  1968. *
  1969. * A multi-level split of the tree on insert will invalidate the original
  1970. * cursor. All callers of this function should assume that the cursor is
  1971. * no longer valid and revalidate it.
  1972. */
  1973. int /* error */
  1974. xfs_bmbt_insert(
  1975. xfs_btree_cur_t *cur,
  1976. int *stat) /* success/failure */
  1977. {
  1978. int error; /* error return value */
  1979. int i;
  1980. int level;
  1981. xfs_fsblock_t nbno;
  1982. xfs_btree_cur_t *ncur;
  1983. xfs_bmbt_rec_t nrec;
  1984. xfs_btree_cur_t *pcur;
  1985. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  1986. level = 0;
  1987. nbno = NULLFSBLOCK;
  1988. xfs_bmbt_disk_set_all(&nrec, &cur->bc_rec.b);
  1989. ncur = NULL;
  1990. pcur = cur;
  1991. do {
  1992. if ((error = xfs_bmbt_insrec(pcur, level++, &nbno, &nrec, &ncur,
  1993. &i))) {
  1994. if (pcur != cur)
  1995. xfs_btree_del_cursor(pcur, XFS_BTREE_ERROR);
  1996. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  1997. return error;
  1998. }
  1999. XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
  2000. if (pcur != cur && (ncur || nbno == NULLFSBLOCK)) {
  2001. cur->bc_nlevels = pcur->bc_nlevels;
  2002. cur->bc_private.b.allocated +=
  2003. pcur->bc_private.b.allocated;
  2004. pcur->bc_private.b.allocated = 0;
  2005. ASSERT((cur->bc_private.b.firstblock != NULLFSBLOCK) ||
  2006. XFS_IS_REALTIME_INODE(cur->bc_private.b.ip));
  2007. cur->bc_private.b.firstblock =
  2008. pcur->bc_private.b.firstblock;
  2009. ASSERT(cur->bc_private.b.flist ==
  2010. pcur->bc_private.b.flist);
  2011. xfs_btree_del_cursor(pcur, XFS_BTREE_NOERROR);
  2012. }
  2013. if (ncur) {
  2014. pcur = ncur;
  2015. ncur = NULL;
  2016. }
  2017. } while (nbno != NULLFSBLOCK);
  2018. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2019. *stat = i;
  2020. return 0;
  2021. error0:
  2022. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2023. return error;
  2024. }
  2025. /*
  2026. * Log fields from the btree block header.
  2027. */
  2028. void
  2029. xfs_bmbt_log_block(
  2030. xfs_btree_cur_t *cur,
  2031. xfs_buf_t *bp,
  2032. int fields)
  2033. {
  2034. int first;
  2035. int last;
  2036. xfs_trans_t *tp;
  2037. static const short offsets[] = {
  2038. offsetof(xfs_bmbt_block_t, bb_magic),
  2039. offsetof(xfs_bmbt_block_t, bb_level),
  2040. offsetof(xfs_bmbt_block_t, bb_numrecs),
  2041. offsetof(xfs_bmbt_block_t, bb_leftsib),
  2042. offsetof(xfs_bmbt_block_t, bb_rightsib),
  2043. sizeof(xfs_bmbt_block_t)
  2044. };
  2045. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  2046. XFS_BMBT_TRACE_ARGBI(cur, bp, fields);
  2047. tp = cur->bc_tp;
  2048. if (bp) {
  2049. xfs_btree_offsets(fields, offsets, XFS_BB_NUM_BITS, &first,
  2050. &last);
  2051. xfs_trans_log_buf(tp, bp, first, last);
  2052. } else
  2053. xfs_trans_log_inode(tp, cur->bc_private.b.ip,
  2054. XFS_ILOG_FBROOT(cur->bc_private.b.whichfork));
  2055. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2056. }
  2057. /*
  2058. * Log record values from the btree block.
  2059. */
  2060. void
  2061. xfs_bmbt_log_recs(
  2062. xfs_btree_cur_t *cur,
  2063. xfs_buf_t *bp,
  2064. int rfirst,
  2065. int rlast)
  2066. {
  2067. xfs_bmbt_block_t *block;
  2068. int first;
  2069. int last;
  2070. xfs_bmbt_rec_t *rp;
  2071. xfs_trans_t *tp;
  2072. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  2073. XFS_BMBT_TRACE_ARGBII(cur, bp, rfirst, rlast);
  2074. ASSERT(bp);
  2075. tp = cur->bc_tp;
  2076. block = XFS_BUF_TO_BMBT_BLOCK(bp);
  2077. rp = XFS_BMAP_REC_DADDR(block, 1, cur);
  2078. first = (int)((xfs_caddr_t)&rp[rfirst - 1] - (xfs_caddr_t)block);
  2079. last = (int)(((xfs_caddr_t)&rp[rlast] - 1) - (xfs_caddr_t)block);
  2080. xfs_trans_log_buf(tp, bp, first, last);
  2081. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2082. }
  2083. int /* error */
  2084. xfs_bmbt_lookup_eq(
  2085. xfs_btree_cur_t *cur,
  2086. xfs_fileoff_t off,
  2087. xfs_fsblock_t bno,
  2088. xfs_filblks_t len,
  2089. int *stat) /* success/failure */
  2090. {
  2091. cur->bc_rec.b.br_startoff = off;
  2092. cur->bc_rec.b.br_startblock = bno;
  2093. cur->bc_rec.b.br_blockcount = len;
  2094. return xfs_bmbt_lookup(cur, XFS_LOOKUP_EQ, stat);
  2095. }
  2096. int /* error */
  2097. xfs_bmbt_lookup_ge(
  2098. xfs_btree_cur_t *cur,
  2099. xfs_fileoff_t off,
  2100. xfs_fsblock_t bno,
  2101. xfs_filblks_t len,
  2102. int *stat) /* success/failure */
  2103. {
  2104. cur->bc_rec.b.br_startoff = off;
  2105. cur->bc_rec.b.br_startblock = bno;
  2106. cur->bc_rec.b.br_blockcount = len;
  2107. return xfs_bmbt_lookup(cur, XFS_LOOKUP_GE, stat);
  2108. }
  2109. /*
  2110. * Give the bmap btree a new root block. Copy the old broot contents
  2111. * down into a real block and make the broot point to it.
  2112. */
  2113. int /* error */
  2114. xfs_bmbt_newroot(
  2115. xfs_btree_cur_t *cur, /* btree cursor */
  2116. int *logflags, /* logging flags for inode */
  2117. int *stat) /* return status - 0 fail */
  2118. {
  2119. xfs_alloc_arg_t args; /* allocation arguments */
  2120. xfs_bmbt_block_t *block; /* bmap btree block */
  2121. xfs_buf_t *bp; /* buffer for block */
  2122. xfs_bmbt_block_t *cblock; /* child btree block */
  2123. xfs_bmbt_key_t *ckp; /* child key pointer */
  2124. xfs_bmbt_ptr_t *cpp; /* child ptr pointer */
  2125. int error; /* error return code */
  2126. #ifdef DEBUG
  2127. int i; /* loop counter */
  2128. #endif
  2129. xfs_bmbt_key_t *kp; /* pointer to bmap btree key */
  2130. int level; /* btree level */
  2131. xfs_bmbt_ptr_t *pp; /* pointer to bmap block addr */
  2132. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  2133. level = cur->bc_nlevels - 1;
  2134. block = xfs_bmbt_get_block(cur, level, &bp);
  2135. /*
  2136. * Copy the root into a real block.
  2137. */
  2138. args.mp = cur->bc_mp;
  2139. pp = XFS_BMAP_PTR_IADDR(block, 1, cur);
  2140. args.tp = cur->bc_tp;
  2141. args.fsbno = cur->bc_private.b.firstblock;
  2142. args.mod = args.minleft = args.alignment = args.total = args.isfl =
  2143. args.userdata = args.minalignslop = 0;
  2144. args.minlen = args.maxlen = args.prod = 1;
  2145. args.wasdel = cur->bc_private.b.flags & XFS_BTCUR_BPRV_WASDEL;
  2146. args.firstblock = args.fsbno;
  2147. if (args.fsbno == NULLFSBLOCK) {
  2148. #ifdef DEBUG
  2149. if ((error = xfs_btree_check_lptr_disk(cur, *pp, level))) {
  2150. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2151. return error;
  2152. }
  2153. #endif
  2154. args.fsbno = be64_to_cpu(*pp);
  2155. args.type = XFS_ALLOCTYPE_START_BNO;
  2156. } else
  2157. args.type = XFS_ALLOCTYPE_NEAR_BNO;
  2158. if ((error = xfs_alloc_vextent(&args))) {
  2159. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2160. return error;
  2161. }
  2162. if (args.fsbno == NULLFSBLOCK) {
  2163. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2164. *stat = 0;
  2165. return 0;
  2166. }
  2167. ASSERT(args.len == 1);
  2168. cur->bc_private.b.firstblock = args.fsbno;
  2169. cur->bc_private.b.allocated++;
  2170. cur->bc_private.b.ip->i_d.di_nblocks++;
  2171. XFS_TRANS_MOD_DQUOT_BYINO(args.mp, args.tp, cur->bc_private.b.ip,
  2172. XFS_TRANS_DQ_BCOUNT, 1L);
  2173. bp = xfs_btree_get_bufl(args.mp, cur->bc_tp, args.fsbno, 0);
  2174. cblock = XFS_BUF_TO_BMBT_BLOCK(bp);
  2175. *cblock = *block;
  2176. be16_add_cpu(&block->bb_level, 1);
  2177. block->bb_numrecs = cpu_to_be16(1);
  2178. cur->bc_nlevels++;
  2179. cur->bc_ptrs[level + 1] = 1;
  2180. kp = XFS_BMAP_KEY_IADDR(block, 1, cur);
  2181. ckp = XFS_BMAP_KEY_IADDR(cblock, 1, cur);
  2182. memcpy(ckp, kp, be16_to_cpu(cblock->bb_numrecs) * sizeof(*kp));
  2183. cpp = XFS_BMAP_PTR_IADDR(cblock, 1, cur);
  2184. #ifdef DEBUG
  2185. for (i = 0; i < be16_to_cpu(cblock->bb_numrecs); i++) {
  2186. if ((error = xfs_btree_check_lptr_disk(cur, pp[i], level))) {
  2187. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2188. return error;
  2189. }
  2190. }
  2191. #endif
  2192. memcpy(cpp, pp, be16_to_cpu(cblock->bb_numrecs) * sizeof(*pp));
  2193. #ifdef DEBUG
  2194. if ((error = xfs_btree_check_lptr(cur, args.fsbno, level))) {
  2195. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2196. return error;
  2197. }
  2198. #endif
  2199. *pp = cpu_to_be64(args.fsbno);
  2200. xfs_iroot_realloc(cur->bc_private.b.ip, 1 - be16_to_cpu(cblock->bb_numrecs),
  2201. cur->bc_private.b.whichfork);
  2202. xfs_btree_setbuf(cur, level, bp);
  2203. /*
  2204. * Do all this logging at the end so that
  2205. * the root is at the right level.
  2206. */
  2207. xfs_bmbt_log_block(cur, bp, XFS_BB_ALL_BITS);
  2208. xfs_bmbt_log_keys(cur, bp, 1, be16_to_cpu(cblock->bb_numrecs));
  2209. xfs_bmbt_log_ptrs(cur, bp, 1, be16_to_cpu(cblock->bb_numrecs));
  2210. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2211. *logflags |=
  2212. XFS_ILOG_CORE | XFS_ILOG_FBROOT(cur->bc_private.b.whichfork);
  2213. *stat = 1;
  2214. return 0;
  2215. }
  2216. /*
  2217. * Set all the fields in a bmap extent record from the arguments.
  2218. */
  2219. void
  2220. xfs_bmbt_set_allf(
  2221. xfs_bmbt_rec_host_t *r,
  2222. xfs_fileoff_t startoff,
  2223. xfs_fsblock_t startblock,
  2224. xfs_filblks_t blockcount,
  2225. xfs_exntst_t state)
  2226. {
  2227. int extent_flag = (state == XFS_EXT_NORM) ? 0 : 1;
  2228. ASSERT(state == XFS_EXT_NORM || state == XFS_EXT_UNWRITTEN);
  2229. ASSERT((startoff & XFS_MASK64HI(64-BMBT_STARTOFF_BITLEN)) == 0);
  2230. ASSERT((blockcount & XFS_MASK64HI(64-BMBT_BLOCKCOUNT_BITLEN)) == 0);
  2231. #if XFS_BIG_BLKNOS
  2232. ASSERT((startblock & XFS_MASK64HI(64-BMBT_STARTBLOCK_BITLEN)) == 0);
  2233. r->l0 = ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  2234. ((xfs_bmbt_rec_base_t)startoff << 9) |
  2235. ((xfs_bmbt_rec_base_t)startblock >> 43);
  2236. r->l1 = ((xfs_bmbt_rec_base_t)startblock << 21) |
  2237. ((xfs_bmbt_rec_base_t)blockcount &
  2238. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  2239. #else /* !XFS_BIG_BLKNOS */
  2240. if (ISNULLSTARTBLOCK(startblock)) {
  2241. r->l0 = ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  2242. ((xfs_bmbt_rec_base_t)startoff << 9) |
  2243. (xfs_bmbt_rec_base_t)XFS_MASK64LO(9);
  2244. r->l1 = XFS_MASK64HI(11) |
  2245. ((xfs_bmbt_rec_base_t)startblock << 21) |
  2246. ((xfs_bmbt_rec_base_t)blockcount &
  2247. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  2248. } else {
  2249. r->l0 = ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  2250. ((xfs_bmbt_rec_base_t)startoff << 9);
  2251. r->l1 = ((xfs_bmbt_rec_base_t)startblock << 21) |
  2252. ((xfs_bmbt_rec_base_t)blockcount &
  2253. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  2254. }
  2255. #endif /* XFS_BIG_BLKNOS */
  2256. }
  2257. /*
  2258. * Set all the fields in a bmap extent record from the uncompressed form.
  2259. */
  2260. void
  2261. xfs_bmbt_set_all(
  2262. xfs_bmbt_rec_host_t *r,
  2263. xfs_bmbt_irec_t *s)
  2264. {
  2265. xfs_bmbt_set_allf(r, s->br_startoff, s->br_startblock,
  2266. s->br_blockcount, s->br_state);
  2267. }
  2268. /*
  2269. * Set all the fields in a disk format bmap extent record from the arguments.
  2270. */
  2271. void
  2272. xfs_bmbt_disk_set_allf(
  2273. xfs_bmbt_rec_t *r,
  2274. xfs_fileoff_t startoff,
  2275. xfs_fsblock_t startblock,
  2276. xfs_filblks_t blockcount,
  2277. xfs_exntst_t state)
  2278. {
  2279. int extent_flag = (state == XFS_EXT_NORM) ? 0 : 1;
  2280. ASSERT(state == XFS_EXT_NORM || state == XFS_EXT_UNWRITTEN);
  2281. ASSERT((startoff & XFS_MASK64HI(64-BMBT_STARTOFF_BITLEN)) == 0);
  2282. ASSERT((blockcount & XFS_MASK64HI(64-BMBT_BLOCKCOUNT_BITLEN)) == 0);
  2283. #if XFS_BIG_BLKNOS
  2284. ASSERT((startblock & XFS_MASK64HI(64-BMBT_STARTBLOCK_BITLEN)) == 0);
  2285. r->l0 = cpu_to_be64(
  2286. ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  2287. ((xfs_bmbt_rec_base_t)startoff << 9) |
  2288. ((xfs_bmbt_rec_base_t)startblock >> 43));
  2289. r->l1 = cpu_to_be64(
  2290. ((xfs_bmbt_rec_base_t)startblock << 21) |
  2291. ((xfs_bmbt_rec_base_t)blockcount &
  2292. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21)));
  2293. #else /* !XFS_BIG_BLKNOS */
  2294. if (ISNULLSTARTBLOCK(startblock)) {
  2295. r->l0 = cpu_to_be64(
  2296. ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  2297. ((xfs_bmbt_rec_base_t)startoff << 9) |
  2298. (xfs_bmbt_rec_base_t)XFS_MASK64LO(9));
  2299. r->l1 = cpu_to_be64(XFS_MASK64HI(11) |
  2300. ((xfs_bmbt_rec_base_t)startblock << 21) |
  2301. ((xfs_bmbt_rec_base_t)blockcount &
  2302. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21)));
  2303. } else {
  2304. r->l0 = cpu_to_be64(
  2305. ((xfs_bmbt_rec_base_t)extent_flag << 63) |
  2306. ((xfs_bmbt_rec_base_t)startoff << 9));
  2307. r->l1 = cpu_to_be64(
  2308. ((xfs_bmbt_rec_base_t)startblock << 21) |
  2309. ((xfs_bmbt_rec_base_t)blockcount &
  2310. (xfs_bmbt_rec_base_t)XFS_MASK64LO(21)));
  2311. }
  2312. #endif /* XFS_BIG_BLKNOS */
  2313. }
  2314. /*
  2315. * Set all the fields in a bmap extent record from the uncompressed form.
  2316. */
  2317. void
  2318. xfs_bmbt_disk_set_all(
  2319. xfs_bmbt_rec_t *r,
  2320. xfs_bmbt_irec_t *s)
  2321. {
  2322. xfs_bmbt_disk_set_allf(r, s->br_startoff, s->br_startblock,
  2323. s->br_blockcount, s->br_state);
  2324. }
  2325. /*
  2326. * Set the blockcount field in a bmap extent record.
  2327. */
  2328. void
  2329. xfs_bmbt_set_blockcount(
  2330. xfs_bmbt_rec_host_t *r,
  2331. xfs_filblks_t v)
  2332. {
  2333. ASSERT((v & XFS_MASK64HI(43)) == 0);
  2334. r->l1 = (r->l1 & (xfs_bmbt_rec_base_t)XFS_MASK64HI(43)) |
  2335. (xfs_bmbt_rec_base_t)(v & XFS_MASK64LO(21));
  2336. }
  2337. /*
  2338. * Set the startblock field in a bmap extent record.
  2339. */
  2340. void
  2341. xfs_bmbt_set_startblock(
  2342. xfs_bmbt_rec_host_t *r,
  2343. xfs_fsblock_t v)
  2344. {
  2345. #if XFS_BIG_BLKNOS
  2346. ASSERT((v & XFS_MASK64HI(12)) == 0);
  2347. r->l0 = (r->l0 & (xfs_bmbt_rec_base_t)XFS_MASK64HI(55)) |
  2348. (xfs_bmbt_rec_base_t)(v >> 43);
  2349. r->l1 = (r->l1 & (xfs_bmbt_rec_base_t)XFS_MASK64LO(21)) |
  2350. (xfs_bmbt_rec_base_t)(v << 21);
  2351. #else /* !XFS_BIG_BLKNOS */
  2352. if (ISNULLSTARTBLOCK(v)) {
  2353. r->l0 |= (xfs_bmbt_rec_base_t)XFS_MASK64LO(9);
  2354. r->l1 = (xfs_bmbt_rec_base_t)XFS_MASK64HI(11) |
  2355. ((xfs_bmbt_rec_base_t)v << 21) |
  2356. (r->l1 & (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  2357. } else {
  2358. r->l0 &= ~(xfs_bmbt_rec_base_t)XFS_MASK64LO(9);
  2359. r->l1 = ((xfs_bmbt_rec_base_t)v << 21) |
  2360. (r->l1 & (xfs_bmbt_rec_base_t)XFS_MASK64LO(21));
  2361. }
  2362. #endif /* XFS_BIG_BLKNOS */
  2363. }
  2364. /*
  2365. * Set the startoff field in a bmap extent record.
  2366. */
  2367. void
  2368. xfs_bmbt_set_startoff(
  2369. xfs_bmbt_rec_host_t *r,
  2370. xfs_fileoff_t v)
  2371. {
  2372. ASSERT((v & XFS_MASK64HI(9)) == 0);
  2373. r->l0 = (r->l0 & (xfs_bmbt_rec_base_t) XFS_MASK64HI(1)) |
  2374. ((xfs_bmbt_rec_base_t)v << 9) |
  2375. (r->l0 & (xfs_bmbt_rec_base_t)XFS_MASK64LO(9));
  2376. }
  2377. /*
  2378. * Set the extent state field in a bmap extent record.
  2379. */
  2380. void
  2381. xfs_bmbt_set_state(
  2382. xfs_bmbt_rec_host_t *r,
  2383. xfs_exntst_t v)
  2384. {
  2385. ASSERT(v == XFS_EXT_NORM || v == XFS_EXT_UNWRITTEN);
  2386. if (v == XFS_EXT_NORM)
  2387. r->l0 &= XFS_MASK64LO(64 - BMBT_EXNTFLAG_BITLEN);
  2388. else
  2389. r->l0 |= XFS_MASK64HI(BMBT_EXNTFLAG_BITLEN);
  2390. }
  2391. /*
  2392. * Convert in-memory form of btree root to on-disk form.
  2393. */
  2394. void
  2395. xfs_bmbt_to_bmdr(
  2396. xfs_bmbt_block_t *rblock,
  2397. int rblocklen,
  2398. xfs_bmdr_block_t *dblock,
  2399. int dblocklen)
  2400. {
  2401. int dmxr;
  2402. xfs_bmbt_key_t *fkp;
  2403. __be64 *fpp;
  2404. xfs_bmbt_key_t *tkp;
  2405. __be64 *tpp;
  2406. ASSERT(be32_to_cpu(rblock->bb_magic) == XFS_BMAP_MAGIC);
  2407. ASSERT(be64_to_cpu(rblock->bb_leftsib) == NULLDFSBNO);
  2408. ASSERT(be64_to_cpu(rblock->bb_rightsib) == NULLDFSBNO);
  2409. ASSERT(be16_to_cpu(rblock->bb_level) > 0);
  2410. dblock->bb_level = rblock->bb_level;
  2411. dblock->bb_numrecs = rblock->bb_numrecs;
  2412. dmxr = (int)XFS_BTREE_BLOCK_MAXRECS(dblocklen, xfs_bmdr, 0);
  2413. fkp = XFS_BMAP_BROOT_KEY_ADDR(rblock, 1, rblocklen);
  2414. tkp = XFS_BTREE_KEY_ADDR(xfs_bmdr, dblock, 1);
  2415. fpp = XFS_BMAP_BROOT_PTR_ADDR(rblock, 1, rblocklen);
  2416. tpp = XFS_BTREE_PTR_ADDR(xfs_bmdr, dblock, 1, dmxr);
  2417. dmxr = be16_to_cpu(dblock->bb_numrecs);
  2418. memcpy(tkp, fkp, sizeof(*fkp) * dmxr);
  2419. memcpy(tpp, fpp, sizeof(*fpp) * dmxr);
  2420. }
  2421. /*
  2422. * Update the record to the passed values.
  2423. */
  2424. int
  2425. xfs_bmbt_update(
  2426. xfs_btree_cur_t *cur,
  2427. xfs_fileoff_t off,
  2428. xfs_fsblock_t bno,
  2429. xfs_filblks_t len,
  2430. xfs_exntst_t state)
  2431. {
  2432. xfs_bmbt_block_t *block;
  2433. xfs_buf_t *bp;
  2434. int error;
  2435. xfs_bmbt_key_t key;
  2436. int ptr;
  2437. xfs_bmbt_rec_t *rp;
  2438. XFS_BMBT_TRACE_CURSOR(cur, ENTRY);
  2439. XFS_BMBT_TRACE_ARGFFFI(cur, (xfs_dfiloff_t)off, (xfs_dfsbno_t)bno,
  2440. (xfs_dfilblks_t)len, (int)state);
  2441. block = xfs_bmbt_get_block(cur, 0, &bp);
  2442. #ifdef DEBUG
  2443. if ((error = xfs_btree_check_lblock(cur, block, 0, bp))) {
  2444. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2445. return error;
  2446. }
  2447. #endif
  2448. ptr = cur->bc_ptrs[0];
  2449. rp = XFS_BMAP_REC_IADDR(block, ptr, cur);
  2450. xfs_bmbt_disk_set_allf(rp, off, bno, len, state);
  2451. xfs_bmbt_log_recs(cur, bp, ptr, ptr);
  2452. if (ptr > 1) {
  2453. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2454. return 0;
  2455. }
  2456. key.br_startoff = cpu_to_be64(off);
  2457. if ((error = xfs_bmbt_updkey(cur, &key, 1))) {
  2458. XFS_BMBT_TRACE_CURSOR(cur, ERROR);
  2459. return error;
  2460. }
  2461. XFS_BMBT_TRACE_CURSOR(cur, EXIT);
  2462. return 0;
  2463. }
  2464. /*
  2465. * Check extent records, which have just been read, for
  2466. * any bit in the extent flag field. ASSERT on debug
  2467. * kernels, as this condition should not occur.
  2468. * Return an error condition (1) if any flags found,
  2469. * otherwise return 0.
  2470. */
  2471. int
  2472. xfs_check_nostate_extents(
  2473. xfs_ifork_t *ifp,
  2474. xfs_extnum_t idx,
  2475. xfs_extnum_t num)
  2476. {
  2477. for (; num > 0; num--, idx++) {
  2478. xfs_bmbt_rec_host_t *ep = xfs_iext_get_ext(ifp, idx);
  2479. if ((ep->l0 >>
  2480. (64 - BMBT_EXNTFLAG_BITLEN)) != 0) {
  2481. ASSERT(0);
  2482. return 1;
  2483. }
  2484. }
  2485. return 0;
  2486. }