xfs_bmap_btree.c 75 KB

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