mballoc.c 135 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456445744584459446044614462446344644465446644674468446944704471447244734474447544764477447844794480448144824483448444854486448744884489449044914492449344944495449644974498449945004501450245034504450545064507450845094510451145124513451445154516451745184519452045214522452345244525452645274528452945304531453245334534453545364537453845394540454145424543454445454546454745484549455045514552455345544555455645574558455945604561456245634564456545664567456845694570457145724573457445754576457745784579458045814582458345844585458645874588458945904591459245934594459545964597459845994600460146024603460446054606460746084609461046114612461346144615461646174618461946204621462246234624462546264627462846294630463146324633463446354636463746384639464046414642464346444645464646474648464946504651465246534654465546564657465846594660466146624663466446654666466746684669467046714672467346744675467646774678467946804681468246834684468546864687468846894690469146924693469446954696469746984699470047014702470347044705470647074708470947104711471247134714471547164717471847194720472147224723472447254726472747284729473047314732473347344735473647374738473947404741474247434744474547464747474847494750475147524753475447554756475747584759476047614762476347644765476647674768476947704771477247734774477547764777477847794780478147824783478447854786478747884789479047914792479347944795479647974798479948004801480248034804480548064807480848094810481148124813481448154816481748184819482048214822482348244825482648274828482948304831483248334834483548364837483848394840484148424843484448454846484748484849485048514852485348544855485648574858485948604861486248634864486548664867486848694870487148724873487448754876487748784879488048814882488348844885488648874888488948904891489248934894489548964897489848994900490149024903490449054906490749084909491049114912491349144915491649174918491949204921492249234924492549264927492849294930493149324933493449354936493749384939494049414942494349444945494649474948494949504951495249534954495549564957495849594960496149624963496449654966496749684969497049714972
  1. /*
  2. * Copyright (c) 2003-2006, Cluster File Systems, Inc, info@clusterfs.com
  3. * Written by Alex Tomas <alex@clusterfs.com>
  4. *
  5. * This program is free software; you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License version 2 as
  7. * published by the Free Software Foundation.
  8. *
  9. * This program is distributed in the hope that it will 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 Licens
  15. * along with this program; if not, write to the Free Software
  16. * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-
  17. */
  18. /*
  19. * mballoc.c contains the multiblocks allocation routines
  20. */
  21. #include "mballoc.h"
  22. #include <linux/debugfs.h>
  23. #include <linux/slab.h>
  24. #include <trace/events/ext4.h>
  25. /*
  26. * MUSTDO:
  27. * - test ext4_ext_search_left() and ext4_ext_search_right()
  28. * - search for metadata in few groups
  29. *
  30. * TODO v4:
  31. * - normalization should take into account whether file is still open
  32. * - discard preallocations if no free space left (policy?)
  33. * - don't normalize tails
  34. * - quota
  35. * - reservation for superuser
  36. *
  37. * TODO v3:
  38. * - bitmap read-ahead (proposed by Oleg Drokin aka green)
  39. * - track min/max extents in each group for better group selection
  40. * - mb_mark_used() may allocate chunk right after splitting buddy
  41. * - tree of groups sorted by number of free blocks
  42. * - error handling
  43. */
  44. /*
  45. * The allocation request involve request for multiple number of blocks
  46. * near to the goal(block) value specified.
  47. *
  48. * During initialization phase of the allocator we decide to use the
  49. * group preallocation or inode preallocation depending on the size of
  50. * the file. The size of the file could be the resulting file size we
  51. * would have after allocation, or the current file size, which ever
  52. * is larger. If the size is less than sbi->s_mb_stream_request we
  53. * select to use the group preallocation. The default value of
  54. * s_mb_stream_request is 16 blocks. This can also be tuned via
  55. * /sys/fs/ext4/<partition>/mb_stream_req. The value is represented in
  56. * terms of number of blocks.
  57. *
  58. * The main motivation for having small file use group preallocation is to
  59. * ensure that we have small files closer together on the disk.
  60. *
  61. * First stage the allocator looks at the inode prealloc list,
  62. * ext4_inode_info->i_prealloc_list, which contains list of prealloc
  63. * spaces for this particular inode. The inode prealloc space is
  64. * represented as:
  65. *
  66. * pa_lstart -> the logical start block for this prealloc space
  67. * pa_pstart -> the physical start block for this prealloc space
  68. * pa_len -> length for this prealloc space
  69. * pa_free -> free space available in this prealloc space
  70. *
  71. * The inode preallocation space is used looking at the _logical_ start
  72. * block. If only the logical file block falls within the range of prealloc
  73. * space we will consume the particular prealloc space. This make sure that
  74. * that the we have contiguous physical blocks representing the file blocks
  75. *
  76. * The important thing to be noted in case of inode prealloc space is that
  77. * we don't modify the values associated to inode prealloc space except
  78. * pa_free.
  79. *
  80. * If we are not able to find blocks in the inode prealloc space and if we
  81. * have the group allocation flag set then we look at the locality group
  82. * prealloc space. These are per CPU prealloc list repreasented as
  83. *
  84. * ext4_sb_info.s_locality_groups[smp_processor_id()]
  85. *
  86. * The reason for having a per cpu locality group is to reduce the contention
  87. * between CPUs. It is possible to get scheduled at this point.
  88. *
  89. * The locality group prealloc space is used looking at whether we have
  90. * enough free space (pa_free) within the prealloc space.
  91. *
  92. * If we can't allocate blocks via inode prealloc or/and locality group
  93. * prealloc then we look at the buddy cache. The buddy cache is represented
  94. * by ext4_sb_info.s_buddy_cache (struct inode) whose file offset gets
  95. * mapped to the buddy and bitmap information regarding different
  96. * groups. The buddy information is attached to buddy cache inode so that
  97. * we can access them through the page cache. The information regarding
  98. * each group is loaded via ext4_mb_load_buddy. The information involve
  99. * block bitmap and buddy information. The information are stored in the
  100. * inode as:
  101. *
  102. * { page }
  103. * [ group 0 bitmap][ group 0 buddy] [group 1][ group 1]...
  104. *
  105. *
  106. * one block each for bitmap and buddy information. So for each group we
  107. * take up 2 blocks. A page can contain blocks_per_page (PAGE_CACHE_SIZE /
  108. * blocksize) blocks. So it can have information regarding groups_per_page
  109. * which is blocks_per_page/2
  110. *
  111. * The buddy cache inode is not stored on disk. The inode is thrown
  112. * away when the filesystem is unmounted.
  113. *
  114. * We look for count number of blocks in the buddy cache. If we were able
  115. * to locate that many free blocks we return with additional information
  116. * regarding rest of the contiguous physical block available
  117. *
  118. * Before allocating blocks via buddy cache we normalize the request
  119. * blocks. This ensure we ask for more blocks that we needed. The extra
  120. * blocks that we get after allocation is added to the respective prealloc
  121. * list. In case of inode preallocation we follow a list of heuristics
  122. * based on file size. This can be found in ext4_mb_normalize_request. If
  123. * we are doing a group prealloc we try to normalize the request to
  124. * sbi->s_mb_group_prealloc. Default value of s_mb_group_prealloc is
  125. * 512 blocks. This can be tuned via
  126. * /sys/fs/ext4/<partition/mb_group_prealloc. The value is represented in
  127. * terms of number of blocks. If we have mounted the file system with -O
  128. * stripe=<value> option the group prealloc request is normalized to the
  129. * stripe value (sbi->s_stripe)
  130. *
  131. * The regular allocator(using the buddy cache) supports few tunables.
  132. *
  133. * /sys/fs/ext4/<partition>/mb_min_to_scan
  134. * /sys/fs/ext4/<partition>/mb_max_to_scan
  135. * /sys/fs/ext4/<partition>/mb_order2_req
  136. *
  137. * The regular allocator uses buddy scan only if the request len is power of
  138. * 2 blocks and the order of allocation is >= sbi->s_mb_order2_reqs. The
  139. * value of s_mb_order2_reqs can be tuned via
  140. * /sys/fs/ext4/<partition>/mb_order2_req. If the request len is equal to
  141. * stripe size (sbi->s_stripe), we try to search for contiguous block in
  142. * stripe size. This should result in better allocation on RAID setups. If
  143. * not, we search in the specific group using bitmap for best extents. The
  144. * tunable min_to_scan and max_to_scan control the behaviour here.
  145. * min_to_scan indicate how long the mballoc __must__ look for a best
  146. * extent and max_to_scan indicates how long the mballoc __can__ look for a
  147. * best extent in the found extents. Searching for the blocks starts with
  148. * the group specified as the goal value in allocation context via
  149. * ac_g_ex. Each group is first checked based on the criteria whether it
  150. * can used for allocation. ext4_mb_good_group explains how the groups are
  151. * checked.
  152. *
  153. * Both the prealloc space are getting populated as above. So for the first
  154. * request we will hit the buddy cache which will result in this prealloc
  155. * space getting filled. The prealloc space is then later used for the
  156. * subsequent request.
  157. */
  158. /*
  159. * mballoc operates on the following data:
  160. * - on-disk bitmap
  161. * - in-core buddy (actually includes buddy and bitmap)
  162. * - preallocation descriptors (PAs)
  163. *
  164. * there are two types of preallocations:
  165. * - inode
  166. * assiged to specific inode and can be used for this inode only.
  167. * it describes part of inode's space preallocated to specific
  168. * physical blocks. any block from that preallocated can be used
  169. * independent. the descriptor just tracks number of blocks left
  170. * unused. so, before taking some block from descriptor, one must
  171. * make sure corresponded logical block isn't allocated yet. this
  172. * also means that freeing any block within descriptor's range
  173. * must discard all preallocated blocks.
  174. * - locality group
  175. * assigned to specific locality group which does not translate to
  176. * permanent set of inodes: inode can join and leave group. space
  177. * from this type of preallocation can be used for any inode. thus
  178. * it's consumed from the beginning to the end.
  179. *
  180. * relation between them can be expressed as:
  181. * in-core buddy = on-disk bitmap + preallocation descriptors
  182. *
  183. * this mean blocks mballoc considers used are:
  184. * - allocated blocks (persistent)
  185. * - preallocated blocks (non-persistent)
  186. *
  187. * consistency in mballoc world means that at any time a block is either
  188. * free or used in ALL structures. notice: "any time" should not be read
  189. * literally -- time is discrete and delimited by locks.
  190. *
  191. * to keep it simple, we don't use block numbers, instead we count number of
  192. * blocks: how many blocks marked used/free in on-disk bitmap, buddy and PA.
  193. *
  194. * all operations can be expressed as:
  195. * - init buddy: buddy = on-disk + PAs
  196. * - new PA: buddy += N; PA = N
  197. * - use inode PA: on-disk += N; PA -= N
  198. * - discard inode PA buddy -= on-disk - PA; PA = 0
  199. * - use locality group PA on-disk += N; PA -= N
  200. * - discard locality group PA buddy -= PA; PA = 0
  201. * note: 'buddy -= on-disk - PA' is used to show that on-disk bitmap
  202. * is used in real operation because we can't know actual used
  203. * bits from PA, only from on-disk bitmap
  204. *
  205. * if we follow this strict logic, then all operations above should be atomic.
  206. * given some of them can block, we'd have to use something like semaphores
  207. * killing performance on high-end SMP hardware. let's try to relax it using
  208. * the following knowledge:
  209. * 1) if buddy is referenced, it's already initialized
  210. * 2) while block is used in buddy and the buddy is referenced,
  211. * nobody can re-allocate that block
  212. * 3) we work on bitmaps and '+' actually means 'set bits'. if on-disk has
  213. * bit set and PA claims same block, it's OK. IOW, one can set bit in
  214. * on-disk bitmap if buddy has same bit set or/and PA covers corresponded
  215. * block
  216. *
  217. * so, now we're building a concurrency table:
  218. * - init buddy vs.
  219. * - new PA
  220. * blocks for PA are allocated in the buddy, buddy must be referenced
  221. * until PA is linked to allocation group to avoid concurrent buddy init
  222. * - use inode PA
  223. * we need to make sure that either on-disk bitmap or PA has uptodate data
  224. * given (3) we care that PA-=N operation doesn't interfere with init
  225. * - discard inode PA
  226. * the simplest way would be to have buddy initialized by the discard
  227. * - use locality group PA
  228. * again PA-=N must be serialized with init
  229. * - discard locality group PA
  230. * the simplest way would be to have buddy initialized by the discard
  231. * - new PA vs.
  232. * - use inode PA
  233. * i_data_sem serializes them
  234. * - discard inode PA
  235. * discard process must wait until PA isn't used by another process
  236. * - use locality group PA
  237. * some mutex should serialize them
  238. * - discard locality group PA
  239. * discard process must wait until PA isn't used by another process
  240. * - use inode PA
  241. * - use inode PA
  242. * i_data_sem or another mutex should serializes them
  243. * - discard inode PA
  244. * discard process must wait until PA isn't used by another process
  245. * - use locality group PA
  246. * nothing wrong here -- they're different PAs covering different blocks
  247. * - discard locality group PA
  248. * discard process must wait until PA isn't used by another process
  249. *
  250. * now we're ready to make few consequences:
  251. * - PA is referenced and while it is no discard is possible
  252. * - PA is referenced until block isn't marked in on-disk bitmap
  253. * - PA changes only after on-disk bitmap
  254. * - discard must not compete with init. either init is done before
  255. * any discard or they're serialized somehow
  256. * - buddy init as sum of on-disk bitmap and PAs is done atomically
  257. *
  258. * a special case when we've used PA to emptiness. no need to modify buddy
  259. * in this case, but we should care about concurrent init
  260. *
  261. */
  262. /*
  263. * Logic in few words:
  264. *
  265. * - allocation:
  266. * load group
  267. * find blocks
  268. * mark bits in on-disk bitmap
  269. * release group
  270. *
  271. * - use preallocation:
  272. * find proper PA (per-inode or group)
  273. * load group
  274. * mark bits in on-disk bitmap
  275. * release group
  276. * release PA
  277. *
  278. * - free:
  279. * load group
  280. * mark bits in on-disk bitmap
  281. * release group
  282. *
  283. * - discard preallocations in group:
  284. * mark PAs deleted
  285. * move them onto local list
  286. * load on-disk bitmap
  287. * load group
  288. * remove PA from object (inode or locality group)
  289. * mark free blocks in-core
  290. *
  291. * - discard inode's preallocations:
  292. */
  293. /*
  294. * Locking rules
  295. *
  296. * Locks:
  297. * - bitlock on a group (group)
  298. * - object (inode/locality) (object)
  299. * - per-pa lock (pa)
  300. *
  301. * Paths:
  302. * - new pa
  303. * object
  304. * group
  305. *
  306. * - find and use pa:
  307. * pa
  308. *
  309. * - release consumed pa:
  310. * pa
  311. * group
  312. * object
  313. *
  314. * - generate in-core bitmap:
  315. * group
  316. * pa
  317. *
  318. * - discard all for given object (inode, locality group):
  319. * object
  320. * pa
  321. * group
  322. *
  323. * - discard all for given group:
  324. * group
  325. * pa
  326. * group
  327. * object
  328. *
  329. */
  330. static struct kmem_cache *ext4_pspace_cachep;
  331. static struct kmem_cache *ext4_ac_cachep;
  332. static struct kmem_cache *ext4_free_ext_cachep;
  333. /* We create slab caches for groupinfo data structures based on the
  334. * superblock block size. There will be one per mounted filesystem for
  335. * each unique s_blocksize_bits */
  336. #define NR_GRPINFO_CACHES 8
  337. static struct kmem_cache *ext4_groupinfo_caches[NR_GRPINFO_CACHES];
  338. static const char *ext4_groupinfo_slab_names[NR_GRPINFO_CACHES] = {
  339. "ext4_groupinfo_1k", "ext4_groupinfo_2k", "ext4_groupinfo_4k",
  340. "ext4_groupinfo_8k", "ext4_groupinfo_16k", "ext4_groupinfo_32k",
  341. "ext4_groupinfo_64k", "ext4_groupinfo_128k"
  342. };
  343. static void ext4_mb_generate_from_pa(struct super_block *sb, void *bitmap,
  344. ext4_group_t group);
  345. static void ext4_mb_generate_from_freelist(struct super_block *sb, void *bitmap,
  346. ext4_group_t group);
  347. static void release_blocks_on_commit(journal_t *journal, transaction_t *txn);
  348. static inline void *mb_correct_addr_and_bit(int *bit, void *addr)
  349. {
  350. #if BITS_PER_LONG == 64
  351. *bit += ((unsigned long) addr & 7UL) << 3;
  352. addr = (void *) ((unsigned long) addr & ~7UL);
  353. #elif BITS_PER_LONG == 32
  354. *bit += ((unsigned long) addr & 3UL) << 3;
  355. addr = (void *) ((unsigned long) addr & ~3UL);
  356. #else
  357. #error "how many bits you are?!"
  358. #endif
  359. return addr;
  360. }
  361. static inline int mb_test_bit(int bit, void *addr)
  362. {
  363. /*
  364. * ext4_test_bit on architecture like powerpc
  365. * needs unsigned long aligned address
  366. */
  367. addr = mb_correct_addr_and_bit(&bit, addr);
  368. return ext4_test_bit(bit, addr);
  369. }
  370. static inline void mb_set_bit(int bit, void *addr)
  371. {
  372. addr = mb_correct_addr_and_bit(&bit, addr);
  373. ext4_set_bit(bit, addr);
  374. }
  375. static inline void mb_clear_bit(int bit, void *addr)
  376. {
  377. addr = mb_correct_addr_and_bit(&bit, addr);
  378. ext4_clear_bit(bit, addr);
  379. }
  380. static inline int mb_find_next_zero_bit(void *addr, int max, int start)
  381. {
  382. int fix = 0, ret, tmpmax;
  383. addr = mb_correct_addr_and_bit(&fix, addr);
  384. tmpmax = max + fix;
  385. start += fix;
  386. ret = ext4_find_next_zero_bit(addr, tmpmax, start) - fix;
  387. if (ret > max)
  388. return max;
  389. return ret;
  390. }
  391. static inline int mb_find_next_bit(void *addr, int max, int start)
  392. {
  393. int fix = 0, ret, tmpmax;
  394. addr = mb_correct_addr_and_bit(&fix, addr);
  395. tmpmax = max + fix;
  396. start += fix;
  397. ret = ext4_find_next_bit(addr, tmpmax, start) - fix;
  398. if (ret > max)
  399. return max;
  400. return ret;
  401. }
  402. static void *mb_find_buddy(struct ext4_buddy *e4b, int order, int *max)
  403. {
  404. char *bb;
  405. BUG_ON(EXT4_MB_BITMAP(e4b) == EXT4_MB_BUDDY(e4b));
  406. BUG_ON(max == NULL);
  407. if (order > e4b->bd_blkbits + 1) {
  408. *max = 0;
  409. return NULL;
  410. }
  411. /* at order 0 we see each particular block */
  412. if (order == 0) {
  413. *max = 1 << (e4b->bd_blkbits + 3);
  414. return EXT4_MB_BITMAP(e4b);
  415. }
  416. bb = EXT4_MB_BUDDY(e4b) + EXT4_SB(e4b->bd_sb)->s_mb_offsets[order];
  417. *max = EXT4_SB(e4b->bd_sb)->s_mb_maxs[order];
  418. return bb;
  419. }
  420. #ifdef DOUBLE_CHECK
  421. static void mb_free_blocks_double(struct inode *inode, struct ext4_buddy *e4b,
  422. int first, int count)
  423. {
  424. int i;
  425. struct super_block *sb = e4b->bd_sb;
  426. if (unlikely(e4b->bd_info->bb_bitmap == NULL))
  427. return;
  428. assert_spin_locked(ext4_group_lock_ptr(sb, e4b->bd_group));
  429. for (i = 0; i < count; i++) {
  430. if (!mb_test_bit(first + i, e4b->bd_info->bb_bitmap)) {
  431. ext4_fsblk_t blocknr;
  432. blocknr = ext4_group_first_block_no(sb, e4b->bd_group);
  433. blocknr += first + i;
  434. ext4_grp_locked_error(sb, e4b->bd_group,
  435. inode ? inode->i_ino : 0,
  436. blocknr,
  437. "freeing block already freed "
  438. "(bit %u)",
  439. first + i);
  440. }
  441. mb_clear_bit(first + i, e4b->bd_info->bb_bitmap);
  442. }
  443. }
  444. static void mb_mark_used_double(struct ext4_buddy *e4b, int first, int count)
  445. {
  446. int i;
  447. if (unlikely(e4b->bd_info->bb_bitmap == NULL))
  448. return;
  449. assert_spin_locked(ext4_group_lock_ptr(e4b->bd_sb, e4b->bd_group));
  450. for (i = 0; i < count; i++) {
  451. BUG_ON(mb_test_bit(first + i, e4b->bd_info->bb_bitmap));
  452. mb_set_bit(first + i, e4b->bd_info->bb_bitmap);
  453. }
  454. }
  455. static void mb_cmp_bitmaps(struct ext4_buddy *e4b, void *bitmap)
  456. {
  457. if (memcmp(e4b->bd_info->bb_bitmap, bitmap, e4b->bd_sb->s_blocksize)) {
  458. unsigned char *b1, *b2;
  459. int i;
  460. b1 = (unsigned char *) e4b->bd_info->bb_bitmap;
  461. b2 = (unsigned char *) bitmap;
  462. for (i = 0; i < e4b->bd_sb->s_blocksize; i++) {
  463. if (b1[i] != b2[i]) {
  464. printk(KERN_ERR "corruption in group %u "
  465. "at byte %u(%u): %x in copy != %x "
  466. "on disk/prealloc\n",
  467. e4b->bd_group, i, i * 8, b1[i], b2[i]);
  468. BUG();
  469. }
  470. }
  471. }
  472. }
  473. #else
  474. static inline void mb_free_blocks_double(struct inode *inode,
  475. struct ext4_buddy *e4b, int first, int count)
  476. {
  477. return;
  478. }
  479. static inline void mb_mark_used_double(struct ext4_buddy *e4b,
  480. int first, int count)
  481. {
  482. return;
  483. }
  484. static inline void mb_cmp_bitmaps(struct ext4_buddy *e4b, void *bitmap)
  485. {
  486. return;
  487. }
  488. #endif
  489. #ifdef AGGRESSIVE_CHECK
  490. #define MB_CHECK_ASSERT(assert) \
  491. do { \
  492. if (!(assert)) { \
  493. printk(KERN_EMERG \
  494. "Assertion failure in %s() at %s:%d: \"%s\"\n", \
  495. function, file, line, # assert); \
  496. BUG(); \
  497. } \
  498. } while (0)
  499. static int __mb_check_buddy(struct ext4_buddy *e4b, char *file,
  500. const char *function, int line)
  501. {
  502. struct super_block *sb = e4b->bd_sb;
  503. int order = e4b->bd_blkbits + 1;
  504. int max;
  505. int max2;
  506. int i;
  507. int j;
  508. int k;
  509. int count;
  510. struct ext4_group_info *grp;
  511. int fragments = 0;
  512. int fstart;
  513. struct list_head *cur;
  514. void *buddy;
  515. void *buddy2;
  516. {
  517. static int mb_check_counter;
  518. if (mb_check_counter++ % 100 != 0)
  519. return 0;
  520. }
  521. while (order > 1) {
  522. buddy = mb_find_buddy(e4b, order, &max);
  523. MB_CHECK_ASSERT(buddy);
  524. buddy2 = mb_find_buddy(e4b, order - 1, &max2);
  525. MB_CHECK_ASSERT(buddy2);
  526. MB_CHECK_ASSERT(buddy != buddy2);
  527. MB_CHECK_ASSERT(max * 2 == max2);
  528. count = 0;
  529. for (i = 0; i < max; i++) {
  530. if (mb_test_bit(i, buddy)) {
  531. /* only single bit in buddy2 may be 1 */
  532. if (!mb_test_bit(i << 1, buddy2)) {
  533. MB_CHECK_ASSERT(
  534. mb_test_bit((i<<1)+1, buddy2));
  535. } else if (!mb_test_bit((i << 1) + 1, buddy2)) {
  536. MB_CHECK_ASSERT(
  537. mb_test_bit(i << 1, buddy2));
  538. }
  539. continue;
  540. }
  541. /* both bits in buddy2 must be 0 */
  542. MB_CHECK_ASSERT(mb_test_bit(i << 1, buddy2));
  543. MB_CHECK_ASSERT(mb_test_bit((i << 1) + 1, buddy2));
  544. for (j = 0; j < (1 << order); j++) {
  545. k = (i * (1 << order)) + j;
  546. MB_CHECK_ASSERT(
  547. !mb_test_bit(k, EXT4_MB_BITMAP(e4b)));
  548. }
  549. count++;
  550. }
  551. MB_CHECK_ASSERT(e4b->bd_info->bb_counters[order] == count);
  552. order--;
  553. }
  554. fstart = -1;
  555. buddy = mb_find_buddy(e4b, 0, &max);
  556. for (i = 0; i < max; i++) {
  557. if (!mb_test_bit(i, buddy)) {
  558. MB_CHECK_ASSERT(i >= e4b->bd_info->bb_first_free);
  559. if (fstart == -1) {
  560. fragments++;
  561. fstart = i;
  562. }
  563. continue;
  564. }
  565. fstart = -1;
  566. /* check used bits only */
  567. for (j = 0; j < e4b->bd_blkbits + 1; j++) {
  568. buddy2 = mb_find_buddy(e4b, j, &max2);
  569. k = i >> j;
  570. MB_CHECK_ASSERT(k < max2);
  571. MB_CHECK_ASSERT(mb_test_bit(k, buddy2));
  572. }
  573. }
  574. MB_CHECK_ASSERT(!EXT4_MB_GRP_NEED_INIT(e4b->bd_info));
  575. MB_CHECK_ASSERT(e4b->bd_info->bb_fragments == fragments);
  576. grp = ext4_get_group_info(sb, e4b->bd_group);
  577. list_for_each(cur, &grp->bb_prealloc_list) {
  578. ext4_group_t groupnr;
  579. struct ext4_prealloc_space *pa;
  580. pa = list_entry(cur, struct ext4_prealloc_space, pa_group_list);
  581. ext4_get_group_no_and_offset(sb, pa->pa_pstart, &groupnr, &k);
  582. MB_CHECK_ASSERT(groupnr == e4b->bd_group);
  583. for (i = 0; i < pa->pa_len; i++)
  584. MB_CHECK_ASSERT(mb_test_bit(k + i, buddy));
  585. }
  586. return 0;
  587. }
  588. #undef MB_CHECK_ASSERT
  589. #define mb_check_buddy(e4b) __mb_check_buddy(e4b, \
  590. __FILE__, __func__, __LINE__)
  591. #else
  592. #define mb_check_buddy(e4b)
  593. #endif
  594. /*
  595. * Divide blocks started from @first with length @len into
  596. * smaller chunks with power of 2 blocks.
  597. * Clear the bits in bitmap which the blocks of the chunk(s) covered,
  598. * then increase bb_counters[] for corresponded chunk size.
  599. */
  600. static void ext4_mb_mark_free_simple(struct super_block *sb,
  601. void *buddy, ext4_grpblk_t first, ext4_grpblk_t len,
  602. struct ext4_group_info *grp)
  603. {
  604. struct ext4_sb_info *sbi = EXT4_SB(sb);
  605. ext4_grpblk_t min;
  606. ext4_grpblk_t max;
  607. ext4_grpblk_t chunk;
  608. unsigned short border;
  609. BUG_ON(len > EXT4_BLOCKS_PER_GROUP(sb));
  610. border = 2 << sb->s_blocksize_bits;
  611. while (len > 0) {
  612. /* find how many blocks can be covered since this position */
  613. max = ffs(first | border) - 1;
  614. /* find how many blocks of power 2 we need to mark */
  615. min = fls(len) - 1;
  616. if (max < min)
  617. min = max;
  618. chunk = 1 << min;
  619. /* mark multiblock chunks only */
  620. grp->bb_counters[min]++;
  621. if (min > 0)
  622. mb_clear_bit(first >> min,
  623. buddy + sbi->s_mb_offsets[min]);
  624. len -= chunk;
  625. first += chunk;
  626. }
  627. }
  628. /*
  629. * Cache the order of the largest free extent we have available in this block
  630. * group.
  631. */
  632. static void
  633. mb_set_largest_free_order(struct super_block *sb, struct ext4_group_info *grp)
  634. {
  635. int i;
  636. int bits;
  637. grp->bb_largest_free_order = -1; /* uninit */
  638. bits = sb->s_blocksize_bits + 1;
  639. for (i = bits; i >= 0; i--) {
  640. if (grp->bb_counters[i] > 0) {
  641. grp->bb_largest_free_order = i;
  642. break;
  643. }
  644. }
  645. }
  646. static noinline_for_stack
  647. void ext4_mb_generate_buddy(struct super_block *sb,
  648. void *buddy, void *bitmap, ext4_group_t group)
  649. {
  650. struct ext4_group_info *grp = ext4_get_group_info(sb, group);
  651. ext4_grpblk_t max = EXT4_BLOCKS_PER_GROUP(sb);
  652. ext4_grpblk_t i = 0;
  653. ext4_grpblk_t first;
  654. ext4_grpblk_t len;
  655. unsigned free = 0;
  656. unsigned fragments = 0;
  657. unsigned long long period = get_cycles();
  658. /* initialize buddy from bitmap which is aggregation
  659. * of on-disk bitmap and preallocations */
  660. i = mb_find_next_zero_bit(bitmap, max, 0);
  661. grp->bb_first_free = i;
  662. while (i < max) {
  663. fragments++;
  664. first = i;
  665. i = mb_find_next_bit(bitmap, max, i);
  666. len = i - first;
  667. free += len;
  668. if (len > 1)
  669. ext4_mb_mark_free_simple(sb, buddy, first, len, grp);
  670. else
  671. grp->bb_counters[0]++;
  672. if (i < max)
  673. i = mb_find_next_zero_bit(bitmap, max, i);
  674. }
  675. grp->bb_fragments = fragments;
  676. if (free != grp->bb_free) {
  677. ext4_grp_locked_error(sb, group, 0, 0,
  678. "%u blocks in bitmap, %u in gd",
  679. free, grp->bb_free);
  680. /*
  681. * If we intent to continue, we consider group descritor
  682. * corrupt and update bb_free using bitmap value
  683. */
  684. grp->bb_free = free;
  685. }
  686. mb_set_largest_free_order(sb, grp);
  687. clear_bit(EXT4_GROUP_INFO_NEED_INIT_BIT, &(grp->bb_state));
  688. period = get_cycles() - period;
  689. spin_lock(&EXT4_SB(sb)->s_bal_lock);
  690. EXT4_SB(sb)->s_mb_buddies_generated++;
  691. EXT4_SB(sb)->s_mb_generation_time += period;
  692. spin_unlock(&EXT4_SB(sb)->s_bal_lock);
  693. }
  694. /* The buddy information is attached the buddy cache inode
  695. * for convenience. The information regarding each group
  696. * is loaded via ext4_mb_load_buddy. The information involve
  697. * block bitmap and buddy information. The information are
  698. * stored in the inode as
  699. *
  700. * { page }
  701. * [ group 0 bitmap][ group 0 buddy] [group 1][ group 1]...
  702. *
  703. *
  704. * one block each for bitmap and buddy information.
  705. * So for each group we take up 2 blocks. A page can
  706. * contain blocks_per_page (PAGE_CACHE_SIZE / blocksize) blocks.
  707. * So it can have information regarding groups_per_page which
  708. * is blocks_per_page/2
  709. *
  710. * Locking note: This routine takes the block group lock of all groups
  711. * for this page; do not hold this lock when calling this routine!
  712. */
  713. static int ext4_mb_init_cache(struct page *page, char *incore)
  714. {
  715. ext4_group_t ngroups;
  716. int blocksize;
  717. int blocks_per_page;
  718. int groups_per_page;
  719. int err = 0;
  720. int i;
  721. ext4_group_t first_group;
  722. int first_block;
  723. struct super_block *sb;
  724. struct buffer_head *bhs;
  725. struct buffer_head **bh;
  726. struct inode *inode;
  727. char *data;
  728. char *bitmap;
  729. struct ext4_group_info *grinfo;
  730. mb_debug(1, "init page %lu\n", page->index);
  731. inode = page->mapping->host;
  732. sb = inode->i_sb;
  733. ngroups = ext4_get_groups_count(sb);
  734. blocksize = 1 << inode->i_blkbits;
  735. blocks_per_page = PAGE_CACHE_SIZE / blocksize;
  736. groups_per_page = blocks_per_page >> 1;
  737. if (groups_per_page == 0)
  738. groups_per_page = 1;
  739. /* allocate buffer_heads to read bitmaps */
  740. if (groups_per_page > 1) {
  741. err = -ENOMEM;
  742. i = sizeof(struct buffer_head *) * groups_per_page;
  743. bh = kzalloc(i, GFP_NOFS);
  744. if (bh == NULL)
  745. goto out;
  746. } else
  747. bh = &bhs;
  748. first_group = page->index * blocks_per_page / 2;
  749. /* read all groups the page covers into the cache */
  750. for (i = 0; i < groups_per_page; i++) {
  751. struct ext4_group_desc *desc;
  752. if (first_group + i >= ngroups)
  753. break;
  754. grinfo = ext4_get_group_info(sb, first_group + i);
  755. /*
  756. * If page is uptodate then we came here after online resize
  757. * which added some new uninitialized group info structs, so
  758. * we must skip all initialized uptodate buddies on the page,
  759. * which may be currently in use by an allocating task.
  760. */
  761. if (PageUptodate(page) && !EXT4_MB_GRP_NEED_INIT(grinfo)) {
  762. bh[i] = NULL;
  763. continue;
  764. }
  765. err = -EIO;
  766. desc = ext4_get_group_desc(sb, first_group + i, NULL);
  767. if (desc == NULL)
  768. goto out;
  769. err = -ENOMEM;
  770. bh[i] = sb_getblk(sb, ext4_block_bitmap(sb, desc));
  771. if (bh[i] == NULL)
  772. goto out;
  773. if (bitmap_uptodate(bh[i]))
  774. continue;
  775. lock_buffer(bh[i]);
  776. if (bitmap_uptodate(bh[i])) {
  777. unlock_buffer(bh[i]);
  778. continue;
  779. }
  780. ext4_lock_group(sb, first_group + i);
  781. if (desc->bg_flags & cpu_to_le16(EXT4_BG_BLOCK_UNINIT)) {
  782. ext4_init_block_bitmap(sb, bh[i],
  783. first_group + i, desc);
  784. set_bitmap_uptodate(bh[i]);
  785. set_buffer_uptodate(bh[i]);
  786. ext4_unlock_group(sb, first_group + i);
  787. unlock_buffer(bh[i]);
  788. continue;
  789. }
  790. ext4_unlock_group(sb, first_group + i);
  791. if (buffer_uptodate(bh[i])) {
  792. /*
  793. * if not uninit if bh is uptodate,
  794. * bitmap is also uptodate
  795. */
  796. set_bitmap_uptodate(bh[i]);
  797. unlock_buffer(bh[i]);
  798. continue;
  799. }
  800. get_bh(bh[i]);
  801. /*
  802. * submit the buffer_head for read. We can
  803. * safely mark the bitmap as uptodate now.
  804. * We do it here so the bitmap uptodate bit
  805. * get set with buffer lock held.
  806. */
  807. set_bitmap_uptodate(bh[i]);
  808. bh[i]->b_end_io = end_buffer_read_sync;
  809. submit_bh(READ, bh[i]);
  810. mb_debug(1, "read bitmap for group %u\n", first_group + i);
  811. }
  812. /* wait for I/O completion */
  813. for (i = 0; i < groups_per_page; i++)
  814. if (bh[i])
  815. wait_on_buffer(bh[i]);
  816. err = -EIO;
  817. for (i = 0; i < groups_per_page; i++)
  818. if (bh[i] && !buffer_uptodate(bh[i]))
  819. goto out;
  820. err = 0;
  821. first_block = page->index * blocks_per_page;
  822. for (i = 0; i < blocks_per_page; i++) {
  823. int group;
  824. group = (first_block + i) >> 1;
  825. if (group >= ngroups)
  826. break;
  827. if (!bh[group - first_group])
  828. /* skip initialized uptodate buddy */
  829. continue;
  830. /*
  831. * data carry information regarding this
  832. * particular group in the format specified
  833. * above
  834. *
  835. */
  836. data = page_address(page) + (i * blocksize);
  837. bitmap = bh[group - first_group]->b_data;
  838. /*
  839. * We place the buddy block and bitmap block
  840. * close together
  841. */
  842. if ((first_block + i) & 1) {
  843. /* this is block of buddy */
  844. BUG_ON(incore == NULL);
  845. mb_debug(1, "put buddy for group %u in page %lu/%x\n",
  846. group, page->index, i * blocksize);
  847. trace_ext4_mb_buddy_bitmap_load(sb, group);
  848. grinfo = ext4_get_group_info(sb, group);
  849. grinfo->bb_fragments = 0;
  850. memset(grinfo->bb_counters, 0,
  851. sizeof(*grinfo->bb_counters) *
  852. (sb->s_blocksize_bits+2));
  853. /*
  854. * incore got set to the group block bitmap below
  855. */
  856. ext4_lock_group(sb, group);
  857. /* init the buddy */
  858. memset(data, 0xff, blocksize);
  859. ext4_mb_generate_buddy(sb, data, incore, group);
  860. ext4_unlock_group(sb, group);
  861. incore = NULL;
  862. } else {
  863. /* this is block of bitmap */
  864. BUG_ON(incore != NULL);
  865. mb_debug(1, "put bitmap for group %u in page %lu/%x\n",
  866. group, page->index, i * blocksize);
  867. trace_ext4_mb_bitmap_load(sb, group);
  868. /* see comments in ext4_mb_put_pa() */
  869. ext4_lock_group(sb, group);
  870. memcpy(data, bitmap, blocksize);
  871. /* mark all preallocated blks used in in-core bitmap */
  872. ext4_mb_generate_from_pa(sb, data, group);
  873. ext4_mb_generate_from_freelist(sb, data, group);
  874. ext4_unlock_group(sb, group);
  875. /* set incore so that the buddy information can be
  876. * generated using this
  877. */
  878. incore = data;
  879. }
  880. }
  881. SetPageUptodate(page);
  882. out:
  883. if (bh) {
  884. for (i = 0; i < groups_per_page; i++)
  885. brelse(bh[i]);
  886. if (bh != &bhs)
  887. kfree(bh);
  888. }
  889. return err;
  890. }
  891. /*
  892. * Lock the buddy and bitmap pages. This make sure other parallel init_group
  893. * on the same buddy page doesn't happen whild holding the buddy page lock.
  894. * Return locked buddy and bitmap pages on e4b struct. If buddy and bitmap
  895. * are on the same page e4b->bd_buddy_page is NULL and return value is 0.
  896. */
  897. static int ext4_mb_get_buddy_page_lock(struct super_block *sb,
  898. ext4_group_t group, struct ext4_buddy *e4b)
  899. {
  900. struct inode *inode = EXT4_SB(sb)->s_buddy_cache;
  901. int block, pnum, poff;
  902. int blocks_per_page;
  903. struct page *page;
  904. e4b->bd_buddy_page = NULL;
  905. e4b->bd_bitmap_page = NULL;
  906. blocks_per_page = PAGE_CACHE_SIZE / sb->s_blocksize;
  907. /*
  908. * the buddy cache inode stores the block bitmap
  909. * and buddy information in consecutive blocks.
  910. * So for each group we need two blocks.
  911. */
  912. block = group * 2;
  913. pnum = block / blocks_per_page;
  914. poff = block % blocks_per_page;
  915. page = find_or_create_page(inode->i_mapping, pnum, GFP_NOFS);
  916. if (!page)
  917. return -EIO;
  918. BUG_ON(page->mapping != inode->i_mapping);
  919. e4b->bd_bitmap_page = page;
  920. e4b->bd_bitmap = page_address(page) + (poff * sb->s_blocksize);
  921. if (blocks_per_page >= 2) {
  922. /* buddy and bitmap are on the same page */
  923. return 0;
  924. }
  925. block++;
  926. pnum = block / blocks_per_page;
  927. poff = block % blocks_per_page;
  928. page = find_or_create_page(inode->i_mapping, pnum, GFP_NOFS);
  929. if (!page)
  930. return -EIO;
  931. BUG_ON(page->mapping != inode->i_mapping);
  932. e4b->bd_buddy_page = page;
  933. return 0;
  934. }
  935. static void ext4_mb_put_buddy_page_lock(struct ext4_buddy *e4b)
  936. {
  937. if (e4b->bd_bitmap_page) {
  938. unlock_page(e4b->bd_bitmap_page);
  939. page_cache_release(e4b->bd_bitmap_page);
  940. }
  941. if (e4b->bd_buddy_page) {
  942. unlock_page(e4b->bd_buddy_page);
  943. page_cache_release(e4b->bd_buddy_page);
  944. }
  945. }
  946. /*
  947. * Locking note: This routine calls ext4_mb_init_cache(), which takes the
  948. * block group lock of all groups for this page; do not hold the BG lock when
  949. * calling this routine!
  950. */
  951. static noinline_for_stack
  952. int ext4_mb_init_group(struct super_block *sb, ext4_group_t group)
  953. {
  954. struct ext4_group_info *this_grp;
  955. struct ext4_buddy e4b;
  956. struct page *page;
  957. int ret = 0;
  958. mb_debug(1, "init group %u\n", group);
  959. this_grp = ext4_get_group_info(sb, group);
  960. /*
  961. * This ensures that we don't reinit the buddy cache
  962. * page which map to the group from which we are already
  963. * allocating. If we are looking at the buddy cache we would
  964. * have taken a reference using ext4_mb_load_buddy and that
  965. * would have pinned buddy page to page cache.
  966. */
  967. ret = ext4_mb_get_buddy_page_lock(sb, group, &e4b);
  968. if (ret || !EXT4_MB_GRP_NEED_INIT(this_grp)) {
  969. /*
  970. * somebody initialized the group
  971. * return without doing anything
  972. */
  973. goto err;
  974. }
  975. page = e4b.bd_bitmap_page;
  976. ret = ext4_mb_init_cache(page, NULL);
  977. if (ret)
  978. goto err;
  979. if (!PageUptodate(page)) {
  980. ret = -EIO;
  981. goto err;
  982. }
  983. mark_page_accessed(page);
  984. if (e4b.bd_buddy_page == NULL) {
  985. /*
  986. * If both the bitmap and buddy are in
  987. * the same page we don't need to force
  988. * init the buddy
  989. */
  990. ret = 0;
  991. goto err;
  992. }
  993. /* init buddy cache */
  994. page = e4b.bd_buddy_page;
  995. ret = ext4_mb_init_cache(page, e4b.bd_bitmap);
  996. if (ret)
  997. goto err;
  998. if (!PageUptodate(page)) {
  999. ret = -EIO;
  1000. goto err;
  1001. }
  1002. mark_page_accessed(page);
  1003. err:
  1004. ext4_mb_put_buddy_page_lock(&e4b);
  1005. return ret;
  1006. }
  1007. /*
  1008. * Locking note: This routine calls ext4_mb_init_cache(), which takes the
  1009. * block group lock of all groups for this page; do not hold the BG lock when
  1010. * calling this routine!
  1011. */
  1012. static noinline_for_stack int
  1013. ext4_mb_load_buddy(struct super_block *sb, ext4_group_t group,
  1014. struct ext4_buddy *e4b)
  1015. {
  1016. int blocks_per_page;
  1017. int block;
  1018. int pnum;
  1019. int poff;
  1020. struct page *page;
  1021. int ret;
  1022. struct ext4_group_info *grp;
  1023. struct ext4_sb_info *sbi = EXT4_SB(sb);
  1024. struct inode *inode = sbi->s_buddy_cache;
  1025. mb_debug(1, "load group %u\n", group);
  1026. blocks_per_page = PAGE_CACHE_SIZE / sb->s_blocksize;
  1027. grp = ext4_get_group_info(sb, group);
  1028. e4b->bd_blkbits = sb->s_blocksize_bits;
  1029. e4b->bd_info = ext4_get_group_info(sb, group);
  1030. e4b->bd_sb = sb;
  1031. e4b->bd_group = group;
  1032. e4b->bd_buddy_page = NULL;
  1033. e4b->bd_bitmap_page = NULL;
  1034. e4b->alloc_semp = &grp->alloc_sem;
  1035. /* Take the read lock on the group alloc
  1036. * sem. This would make sure a parallel
  1037. * ext4_mb_init_group happening on other
  1038. * groups mapped by the page is blocked
  1039. * till we are done with allocation
  1040. */
  1041. repeat_load_buddy:
  1042. down_read(e4b->alloc_semp);
  1043. if (unlikely(EXT4_MB_GRP_NEED_INIT(grp))) {
  1044. /* we need to check for group need init flag
  1045. * with alloc_semp held so that we can be sure
  1046. * that new blocks didn't get added to the group
  1047. * when we are loading the buddy cache
  1048. */
  1049. up_read(e4b->alloc_semp);
  1050. /*
  1051. * we need full data about the group
  1052. * to make a good selection
  1053. */
  1054. ret = ext4_mb_init_group(sb, group);
  1055. if (ret)
  1056. return ret;
  1057. goto repeat_load_buddy;
  1058. }
  1059. /*
  1060. * the buddy cache inode stores the block bitmap
  1061. * and buddy information in consecutive blocks.
  1062. * So for each group we need two blocks.
  1063. */
  1064. block = group * 2;
  1065. pnum = block / blocks_per_page;
  1066. poff = block % blocks_per_page;
  1067. /* we could use find_or_create_page(), but it locks page
  1068. * what we'd like to avoid in fast path ... */
  1069. page = find_get_page(inode->i_mapping, pnum);
  1070. if (page == NULL || !PageUptodate(page)) {
  1071. if (page)
  1072. /*
  1073. * drop the page reference and try
  1074. * to get the page with lock. If we
  1075. * are not uptodate that implies
  1076. * somebody just created the page but
  1077. * is yet to initialize the same. So
  1078. * wait for it to initialize.
  1079. */
  1080. page_cache_release(page);
  1081. page = find_or_create_page(inode->i_mapping, pnum, GFP_NOFS);
  1082. if (page) {
  1083. BUG_ON(page->mapping != inode->i_mapping);
  1084. if (!PageUptodate(page)) {
  1085. ret = ext4_mb_init_cache(page, NULL);
  1086. if (ret) {
  1087. unlock_page(page);
  1088. goto err;
  1089. }
  1090. mb_cmp_bitmaps(e4b, page_address(page) +
  1091. (poff * sb->s_blocksize));
  1092. }
  1093. unlock_page(page);
  1094. }
  1095. }
  1096. if (page == NULL || !PageUptodate(page)) {
  1097. ret = -EIO;
  1098. goto err;
  1099. }
  1100. e4b->bd_bitmap_page = page;
  1101. e4b->bd_bitmap = page_address(page) + (poff * sb->s_blocksize);
  1102. mark_page_accessed(page);
  1103. block++;
  1104. pnum = block / blocks_per_page;
  1105. poff = block % blocks_per_page;
  1106. page = find_get_page(inode->i_mapping, pnum);
  1107. if (page == NULL || !PageUptodate(page)) {
  1108. if (page)
  1109. page_cache_release(page);
  1110. page = find_or_create_page(inode->i_mapping, pnum, GFP_NOFS);
  1111. if (page) {
  1112. BUG_ON(page->mapping != inode->i_mapping);
  1113. if (!PageUptodate(page)) {
  1114. ret = ext4_mb_init_cache(page, e4b->bd_bitmap);
  1115. if (ret) {
  1116. unlock_page(page);
  1117. goto err;
  1118. }
  1119. }
  1120. unlock_page(page);
  1121. }
  1122. }
  1123. if (page == NULL || !PageUptodate(page)) {
  1124. ret = -EIO;
  1125. goto err;
  1126. }
  1127. e4b->bd_buddy_page = page;
  1128. e4b->bd_buddy = page_address(page) + (poff * sb->s_blocksize);
  1129. mark_page_accessed(page);
  1130. BUG_ON(e4b->bd_bitmap_page == NULL);
  1131. BUG_ON(e4b->bd_buddy_page == NULL);
  1132. return 0;
  1133. err:
  1134. if (page)
  1135. page_cache_release(page);
  1136. if (e4b->bd_bitmap_page)
  1137. page_cache_release(e4b->bd_bitmap_page);
  1138. if (e4b->bd_buddy_page)
  1139. page_cache_release(e4b->bd_buddy_page);
  1140. e4b->bd_buddy = NULL;
  1141. e4b->bd_bitmap = NULL;
  1142. /* Done with the buddy cache */
  1143. up_read(e4b->alloc_semp);
  1144. return ret;
  1145. }
  1146. static void ext4_mb_unload_buddy(struct ext4_buddy *e4b)
  1147. {
  1148. if (e4b->bd_bitmap_page)
  1149. page_cache_release(e4b->bd_bitmap_page);
  1150. if (e4b->bd_buddy_page)
  1151. page_cache_release(e4b->bd_buddy_page);
  1152. /* Done with the buddy cache */
  1153. if (e4b->alloc_semp)
  1154. up_read(e4b->alloc_semp);
  1155. }
  1156. static int mb_find_order_for_block(struct ext4_buddy *e4b, int block)
  1157. {
  1158. int order = 1;
  1159. void *bb;
  1160. BUG_ON(EXT4_MB_BITMAP(e4b) == EXT4_MB_BUDDY(e4b));
  1161. BUG_ON(block >= (1 << (e4b->bd_blkbits + 3)));
  1162. bb = EXT4_MB_BUDDY(e4b);
  1163. while (order <= e4b->bd_blkbits + 1) {
  1164. block = block >> 1;
  1165. if (!mb_test_bit(block, bb)) {
  1166. /* this block is part of buddy of order 'order' */
  1167. return order;
  1168. }
  1169. bb += 1 << (e4b->bd_blkbits - order);
  1170. order++;
  1171. }
  1172. return 0;
  1173. }
  1174. static void mb_clear_bits(void *bm, int cur, int len)
  1175. {
  1176. __u32 *addr;
  1177. len = cur + len;
  1178. while (cur < len) {
  1179. if ((cur & 31) == 0 && (len - cur) >= 32) {
  1180. /* fast path: clear whole word at once */
  1181. addr = bm + (cur >> 3);
  1182. *addr = 0;
  1183. cur += 32;
  1184. continue;
  1185. }
  1186. mb_clear_bit(cur, bm);
  1187. cur++;
  1188. }
  1189. }
  1190. static void mb_set_bits(void *bm, int cur, int len)
  1191. {
  1192. __u32 *addr;
  1193. len = cur + len;
  1194. while (cur < len) {
  1195. if ((cur & 31) == 0 && (len - cur) >= 32) {
  1196. /* fast path: set whole word at once */
  1197. addr = bm + (cur >> 3);
  1198. *addr = 0xffffffff;
  1199. cur += 32;
  1200. continue;
  1201. }
  1202. mb_set_bit(cur, bm);
  1203. cur++;
  1204. }
  1205. }
  1206. static void mb_free_blocks(struct inode *inode, struct ext4_buddy *e4b,
  1207. int first, int count)
  1208. {
  1209. int block = 0;
  1210. int max = 0;
  1211. int order;
  1212. void *buddy;
  1213. void *buddy2;
  1214. struct super_block *sb = e4b->bd_sb;
  1215. BUG_ON(first + count > (sb->s_blocksize << 3));
  1216. assert_spin_locked(ext4_group_lock_ptr(sb, e4b->bd_group));
  1217. mb_check_buddy(e4b);
  1218. mb_free_blocks_double(inode, e4b, first, count);
  1219. e4b->bd_info->bb_free += count;
  1220. if (first < e4b->bd_info->bb_first_free)
  1221. e4b->bd_info->bb_first_free = first;
  1222. /* let's maintain fragments counter */
  1223. if (first != 0)
  1224. block = !mb_test_bit(first - 1, EXT4_MB_BITMAP(e4b));
  1225. if (first + count < EXT4_SB(sb)->s_mb_maxs[0])
  1226. max = !mb_test_bit(first + count, EXT4_MB_BITMAP(e4b));
  1227. if (block && max)
  1228. e4b->bd_info->bb_fragments--;
  1229. else if (!block && !max)
  1230. e4b->bd_info->bb_fragments++;
  1231. /* let's maintain buddy itself */
  1232. while (count-- > 0) {
  1233. block = first++;
  1234. order = 0;
  1235. if (!mb_test_bit(block, EXT4_MB_BITMAP(e4b))) {
  1236. ext4_fsblk_t blocknr;
  1237. blocknr = ext4_group_first_block_no(sb, e4b->bd_group);
  1238. blocknr += block;
  1239. ext4_grp_locked_error(sb, e4b->bd_group,
  1240. inode ? inode->i_ino : 0,
  1241. blocknr,
  1242. "freeing already freed block "
  1243. "(bit %u)", block);
  1244. }
  1245. mb_clear_bit(block, EXT4_MB_BITMAP(e4b));
  1246. e4b->bd_info->bb_counters[order]++;
  1247. /* start of the buddy */
  1248. buddy = mb_find_buddy(e4b, order, &max);
  1249. do {
  1250. block &= ~1UL;
  1251. if (mb_test_bit(block, buddy) ||
  1252. mb_test_bit(block + 1, buddy))
  1253. break;
  1254. /* both the buddies are free, try to coalesce them */
  1255. buddy2 = mb_find_buddy(e4b, order + 1, &max);
  1256. if (!buddy2)
  1257. break;
  1258. if (order > 0) {
  1259. /* for special purposes, we don't set
  1260. * free bits in bitmap */
  1261. mb_set_bit(block, buddy);
  1262. mb_set_bit(block + 1, buddy);
  1263. }
  1264. e4b->bd_info->bb_counters[order]--;
  1265. e4b->bd_info->bb_counters[order]--;
  1266. block = block >> 1;
  1267. order++;
  1268. e4b->bd_info->bb_counters[order]++;
  1269. mb_clear_bit(block, buddy2);
  1270. buddy = buddy2;
  1271. } while (1);
  1272. }
  1273. mb_set_largest_free_order(sb, e4b->bd_info);
  1274. mb_check_buddy(e4b);
  1275. }
  1276. static int mb_find_extent(struct ext4_buddy *e4b, int order, int block,
  1277. int needed, struct ext4_free_extent *ex)
  1278. {
  1279. int next = block;
  1280. int max;
  1281. int ord;
  1282. void *buddy;
  1283. assert_spin_locked(ext4_group_lock_ptr(e4b->bd_sb, e4b->bd_group));
  1284. BUG_ON(ex == NULL);
  1285. buddy = mb_find_buddy(e4b, order, &max);
  1286. BUG_ON(buddy == NULL);
  1287. BUG_ON(block >= max);
  1288. if (mb_test_bit(block, buddy)) {
  1289. ex->fe_len = 0;
  1290. ex->fe_start = 0;
  1291. ex->fe_group = 0;
  1292. return 0;
  1293. }
  1294. /* FIXME dorp order completely ? */
  1295. if (likely(order == 0)) {
  1296. /* find actual order */
  1297. order = mb_find_order_for_block(e4b, block);
  1298. block = block >> order;
  1299. }
  1300. ex->fe_len = 1 << order;
  1301. ex->fe_start = block << order;
  1302. ex->fe_group = e4b->bd_group;
  1303. /* calc difference from given start */
  1304. next = next - ex->fe_start;
  1305. ex->fe_len -= next;
  1306. ex->fe_start += next;
  1307. while (needed > ex->fe_len &&
  1308. (buddy = mb_find_buddy(e4b, order, &max))) {
  1309. if (block + 1 >= max)
  1310. break;
  1311. next = (block + 1) * (1 << order);
  1312. if (mb_test_bit(next, EXT4_MB_BITMAP(e4b)))
  1313. break;
  1314. ord = mb_find_order_for_block(e4b, next);
  1315. order = ord;
  1316. block = next >> order;
  1317. ex->fe_len += 1 << order;
  1318. }
  1319. BUG_ON(ex->fe_start + ex->fe_len > (1 << (e4b->bd_blkbits + 3)));
  1320. return ex->fe_len;
  1321. }
  1322. static int mb_mark_used(struct ext4_buddy *e4b, struct ext4_free_extent *ex)
  1323. {
  1324. int ord;
  1325. int mlen = 0;
  1326. int max = 0;
  1327. int cur;
  1328. int start = ex->fe_start;
  1329. int len = ex->fe_len;
  1330. unsigned ret = 0;
  1331. int len0 = len;
  1332. void *buddy;
  1333. BUG_ON(start + len > (e4b->bd_sb->s_blocksize << 3));
  1334. BUG_ON(e4b->bd_group != ex->fe_group);
  1335. assert_spin_locked(ext4_group_lock_ptr(e4b->bd_sb, e4b->bd_group));
  1336. mb_check_buddy(e4b);
  1337. mb_mark_used_double(e4b, start, len);
  1338. e4b->bd_info->bb_free -= len;
  1339. if (e4b->bd_info->bb_first_free == start)
  1340. e4b->bd_info->bb_first_free += len;
  1341. /* let's maintain fragments counter */
  1342. if (start != 0)
  1343. mlen = !mb_test_bit(start - 1, EXT4_MB_BITMAP(e4b));
  1344. if (start + len < EXT4_SB(e4b->bd_sb)->s_mb_maxs[0])
  1345. max = !mb_test_bit(start + len, EXT4_MB_BITMAP(e4b));
  1346. if (mlen && max)
  1347. e4b->bd_info->bb_fragments++;
  1348. else if (!mlen && !max)
  1349. e4b->bd_info->bb_fragments--;
  1350. /* let's maintain buddy itself */
  1351. while (len) {
  1352. ord = mb_find_order_for_block(e4b, start);
  1353. if (((start >> ord) << ord) == start && len >= (1 << ord)) {
  1354. /* the whole chunk may be allocated at once! */
  1355. mlen = 1 << ord;
  1356. buddy = mb_find_buddy(e4b, ord, &max);
  1357. BUG_ON((start >> ord) >= max);
  1358. mb_set_bit(start >> ord, buddy);
  1359. e4b->bd_info->bb_counters[ord]--;
  1360. start += mlen;
  1361. len -= mlen;
  1362. BUG_ON(len < 0);
  1363. continue;
  1364. }
  1365. /* store for history */
  1366. if (ret == 0)
  1367. ret = len | (ord << 16);
  1368. /* we have to split large buddy */
  1369. BUG_ON(ord <= 0);
  1370. buddy = mb_find_buddy(e4b, ord, &max);
  1371. mb_set_bit(start >> ord, buddy);
  1372. e4b->bd_info->bb_counters[ord]--;
  1373. ord--;
  1374. cur = (start >> ord) & ~1U;
  1375. buddy = mb_find_buddy(e4b, ord, &max);
  1376. mb_clear_bit(cur, buddy);
  1377. mb_clear_bit(cur + 1, buddy);
  1378. e4b->bd_info->bb_counters[ord]++;
  1379. e4b->bd_info->bb_counters[ord]++;
  1380. }
  1381. mb_set_largest_free_order(e4b->bd_sb, e4b->bd_info);
  1382. mb_set_bits(EXT4_MB_BITMAP(e4b), ex->fe_start, len0);
  1383. mb_check_buddy(e4b);
  1384. return ret;
  1385. }
  1386. /*
  1387. * Must be called under group lock!
  1388. */
  1389. static void ext4_mb_use_best_found(struct ext4_allocation_context *ac,
  1390. struct ext4_buddy *e4b)
  1391. {
  1392. struct ext4_sb_info *sbi = EXT4_SB(ac->ac_sb);
  1393. int ret;
  1394. BUG_ON(ac->ac_b_ex.fe_group != e4b->bd_group);
  1395. BUG_ON(ac->ac_status == AC_STATUS_FOUND);
  1396. ac->ac_b_ex.fe_len = min(ac->ac_b_ex.fe_len, ac->ac_g_ex.fe_len);
  1397. ac->ac_b_ex.fe_logical = ac->ac_g_ex.fe_logical;
  1398. ret = mb_mark_used(e4b, &ac->ac_b_ex);
  1399. /* preallocation can change ac_b_ex, thus we store actually
  1400. * allocated blocks for history */
  1401. ac->ac_f_ex = ac->ac_b_ex;
  1402. ac->ac_status = AC_STATUS_FOUND;
  1403. ac->ac_tail = ret & 0xffff;
  1404. ac->ac_buddy = ret >> 16;
  1405. /*
  1406. * take the page reference. We want the page to be pinned
  1407. * so that we don't get a ext4_mb_init_cache_call for this
  1408. * group until we update the bitmap. That would mean we
  1409. * double allocate blocks. The reference is dropped
  1410. * in ext4_mb_release_context
  1411. */
  1412. ac->ac_bitmap_page = e4b->bd_bitmap_page;
  1413. get_page(ac->ac_bitmap_page);
  1414. ac->ac_buddy_page = e4b->bd_buddy_page;
  1415. get_page(ac->ac_buddy_page);
  1416. /* on allocation we use ac to track the held semaphore */
  1417. ac->alloc_semp = e4b->alloc_semp;
  1418. e4b->alloc_semp = NULL;
  1419. /* store last allocated for subsequent stream allocation */
  1420. if (ac->ac_flags & EXT4_MB_STREAM_ALLOC) {
  1421. spin_lock(&sbi->s_md_lock);
  1422. sbi->s_mb_last_group = ac->ac_f_ex.fe_group;
  1423. sbi->s_mb_last_start = ac->ac_f_ex.fe_start;
  1424. spin_unlock(&sbi->s_md_lock);
  1425. }
  1426. }
  1427. /*
  1428. * regular allocator, for general purposes allocation
  1429. */
  1430. static void ext4_mb_check_limits(struct ext4_allocation_context *ac,
  1431. struct ext4_buddy *e4b,
  1432. int finish_group)
  1433. {
  1434. struct ext4_sb_info *sbi = EXT4_SB(ac->ac_sb);
  1435. struct ext4_free_extent *bex = &ac->ac_b_ex;
  1436. struct ext4_free_extent *gex = &ac->ac_g_ex;
  1437. struct ext4_free_extent ex;
  1438. int max;
  1439. if (ac->ac_status == AC_STATUS_FOUND)
  1440. return;
  1441. /*
  1442. * We don't want to scan for a whole year
  1443. */
  1444. if (ac->ac_found > sbi->s_mb_max_to_scan &&
  1445. !(ac->ac_flags & EXT4_MB_HINT_FIRST)) {
  1446. ac->ac_status = AC_STATUS_BREAK;
  1447. return;
  1448. }
  1449. /*
  1450. * Haven't found good chunk so far, let's continue
  1451. */
  1452. if (bex->fe_len < gex->fe_len)
  1453. return;
  1454. if ((finish_group || ac->ac_found > sbi->s_mb_min_to_scan)
  1455. && bex->fe_group == e4b->bd_group) {
  1456. /* recheck chunk's availability - we don't know
  1457. * when it was found (within this lock-unlock
  1458. * period or not) */
  1459. max = mb_find_extent(e4b, 0, bex->fe_start, gex->fe_len, &ex);
  1460. if (max >= gex->fe_len) {
  1461. ext4_mb_use_best_found(ac, e4b);
  1462. return;
  1463. }
  1464. }
  1465. }
  1466. /*
  1467. * The routine checks whether found extent is good enough. If it is,
  1468. * then the extent gets marked used and flag is set to the context
  1469. * to stop scanning. Otherwise, the extent is compared with the
  1470. * previous found extent and if new one is better, then it's stored
  1471. * in the context. Later, the best found extent will be used, if
  1472. * mballoc can't find good enough extent.
  1473. *
  1474. * FIXME: real allocation policy is to be designed yet!
  1475. */
  1476. static void ext4_mb_measure_extent(struct ext4_allocation_context *ac,
  1477. struct ext4_free_extent *ex,
  1478. struct ext4_buddy *e4b)
  1479. {
  1480. struct ext4_free_extent *bex = &ac->ac_b_ex;
  1481. struct ext4_free_extent *gex = &ac->ac_g_ex;
  1482. BUG_ON(ex->fe_len <= 0);
  1483. BUG_ON(ex->fe_len > EXT4_BLOCKS_PER_GROUP(ac->ac_sb));
  1484. BUG_ON(ex->fe_start >= EXT4_BLOCKS_PER_GROUP(ac->ac_sb));
  1485. BUG_ON(ac->ac_status != AC_STATUS_CONTINUE);
  1486. ac->ac_found++;
  1487. /*
  1488. * The special case - take what you catch first
  1489. */
  1490. if (unlikely(ac->ac_flags & EXT4_MB_HINT_FIRST)) {
  1491. *bex = *ex;
  1492. ext4_mb_use_best_found(ac, e4b);
  1493. return;
  1494. }
  1495. /*
  1496. * Let's check whether the chuck is good enough
  1497. */
  1498. if (ex->fe_len == gex->fe_len) {
  1499. *bex = *ex;
  1500. ext4_mb_use_best_found(ac, e4b);
  1501. return;
  1502. }
  1503. /*
  1504. * If this is first found extent, just store it in the context
  1505. */
  1506. if (bex->fe_len == 0) {
  1507. *bex = *ex;
  1508. return;
  1509. }
  1510. /*
  1511. * If new found extent is better, store it in the context
  1512. */
  1513. if (bex->fe_len < gex->fe_len) {
  1514. /* if the request isn't satisfied, any found extent
  1515. * larger than previous best one is better */
  1516. if (ex->fe_len > bex->fe_len)
  1517. *bex = *ex;
  1518. } else if (ex->fe_len > gex->fe_len) {
  1519. /* if the request is satisfied, then we try to find
  1520. * an extent that still satisfy the request, but is
  1521. * smaller than previous one */
  1522. if (ex->fe_len < bex->fe_len)
  1523. *bex = *ex;
  1524. }
  1525. ext4_mb_check_limits(ac, e4b, 0);
  1526. }
  1527. static noinline_for_stack
  1528. int ext4_mb_try_best_found(struct ext4_allocation_context *ac,
  1529. struct ext4_buddy *e4b)
  1530. {
  1531. struct ext4_free_extent ex = ac->ac_b_ex;
  1532. ext4_group_t group = ex.fe_group;
  1533. int max;
  1534. int err;
  1535. BUG_ON(ex.fe_len <= 0);
  1536. err = ext4_mb_load_buddy(ac->ac_sb, group, e4b);
  1537. if (err)
  1538. return err;
  1539. ext4_lock_group(ac->ac_sb, group);
  1540. max = mb_find_extent(e4b, 0, ex.fe_start, ex.fe_len, &ex);
  1541. if (max > 0) {
  1542. ac->ac_b_ex = ex;
  1543. ext4_mb_use_best_found(ac, e4b);
  1544. }
  1545. ext4_unlock_group(ac->ac_sb, group);
  1546. ext4_mb_unload_buddy(e4b);
  1547. return 0;
  1548. }
  1549. static noinline_for_stack
  1550. int ext4_mb_find_by_goal(struct ext4_allocation_context *ac,
  1551. struct ext4_buddy *e4b)
  1552. {
  1553. ext4_group_t group = ac->ac_g_ex.fe_group;
  1554. int max;
  1555. int err;
  1556. struct ext4_sb_info *sbi = EXT4_SB(ac->ac_sb);
  1557. struct ext4_free_extent ex;
  1558. if (!(ac->ac_flags & EXT4_MB_HINT_TRY_GOAL))
  1559. return 0;
  1560. err = ext4_mb_load_buddy(ac->ac_sb, group, e4b);
  1561. if (err)
  1562. return err;
  1563. ext4_lock_group(ac->ac_sb, group);
  1564. max = mb_find_extent(e4b, 0, ac->ac_g_ex.fe_start,
  1565. ac->ac_g_ex.fe_len, &ex);
  1566. if (max >= ac->ac_g_ex.fe_len && ac->ac_g_ex.fe_len == sbi->s_stripe) {
  1567. ext4_fsblk_t start;
  1568. start = ext4_group_first_block_no(ac->ac_sb, e4b->bd_group) +
  1569. ex.fe_start;
  1570. /* use do_div to get remainder (would be 64-bit modulo) */
  1571. if (do_div(start, sbi->s_stripe) == 0) {
  1572. ac->ac_found++;
  1573. ac->ac_b_ex = ex;
  1574. ext4_mb_use_best_found(ac, e4b);
  1575. }
  1576. } else if (max >= ac->ac_g_ex.fe_len) {
  1577. BUG_ON(ex.fe_len <= 0);
  1578. BUG_ON(ex.fe_group != ac->ac_g_ex.fe_group);
  1579. BUG_ON(ex.fe_start != ac->ac_g_ex.fe_start);
  1580. ac->ac_found++;
  1581. ac->ac_b_ex = ex;
  1582. ext4_mb_use_best_found(ac, e4b);
  1583. } else if (max > 0 && (ac->ac_flags & EXT4_MB_HINT_MERGE)) {
  1584. /* Sometimes, caller may want to merge even small
  1585. * number of blocks to an existing extent */
  1586. BUG_ON(ex.fe_len <= 0);
  1587. BUG_ON(ex.fe_group != ac->ac_g_ex.fe_group);
  1588. BUG_ON(ex.fe_start != ac->ac_g_ex.fe_start);
  1589. ac->ac_found++;
  1590. ac->ac_b_ex = ex;
  1591. ext4_mb_use_best_found(ac, e4b);
  1592. }
  1593. ext4_unlock_group(ac->ac_sb, group);
  1594. ext4_mb_unload_buddy(e4b);
  1595. return 0;
  1596. }
  1597. /*
  1598. * The routine scans buddy structures (not bitmap!) from given order
  1599. * to max order and tries to find big enough chunk to satisfy the req
  1600. */
  1601. static noinline_for_stack
  1602. void ext4_mb_simple_scan_group(struct ext4_allocation_context *ac,
  1603. struct ext4_buddy *e4b)
  1604. {
  1605. struct super_block *sb = ac->ac_sb;
  1606. struct ext4_group_info *grp = e4b->bd_info;
  1607. void *buddy;
  1608. int i;
  1609. int k;
  1610. int max;
  1611. BUG_ON(ac->ac_2order <= 0);
  1612. for (i = ac->ac_2order; i <= sb->s_blocksize_bits + 1; i++) {
  1613. if (grp->bb_counters[i] == 0)
  1614. continue;
  1615. buddy = mb_find_buddy(e4b, i, &max);
  1616. BUG_ON(buddy == NULL);
  1617. k = mb_find_next_zero_bit(buddy, max, 0);
  1618. BUG_ON(k >= max);
  1619. ac->ac_found++;
  1620. ac->ac_b_ex.fe_len = 1 << i;
  1621. ac->ac_b_ex.fe_start = k << i;
  1622. ac->ac_b_ex.fe_group = e4b->bd_group;
  1623. ext4_mb_use_best_found(ac, e4b);
  1624. BUG_ON(ac->ac_b_ex.fe_len != ac->ac_g_ex.fe_len);
  1625. if (EXT4_SB(sb)->s_mb_stats)
  1626. atomic_inc(&EXT4_SB(sb)->s_bal_2orders);
  1627. break;
  1628. }
  1629. }
  1630. /*
  1631. * The routine scans the group and measures all found extents.
  1632. * In order to optimize scanning, caller must pass number of
  1633. * free blocks in the group, so the routine can know upper limit.
  1634. */
  1635. static noinline_for_stack
  1636. void ext4_mb_complex_scan_group(struct ext4_allocation_context *ac,
  1637. struct ext4_buddy *e4b)
  1638. {
  1639. struct super_block *sb = ac->ac_sb;
  1640. void *bitmap = EXT4_MB_BITMAP(e4b);
  1641. struct ext4_free_extent ex;
  1642. int i;
  1643. int free;
  1644. free = e4b->bd_info->bb_free;
  1645. BUG_ON(free <= 0);
  1646. i = e4b->bd_info->bb_first_free;
  1647. while (free && ac->ac_status == AC_STATUS_CONTINUE) {
  1648. i = mb_find_next_zero_bit(bitmap,
  1649. EXT4_BLOCKS_PER_GROUP(sb), i);
  1650. if (i >= EXT4_BLOCKS_PER_GROUP(sb)) {
  1651. /*
  1652. * IF we have corrupt bitmap, we won't find any
  1653. * free blocks even though group info says we
  1654. * we have free blocks
  1655. */
  1656. ext4_grp_locked_error(sb, e4b->bd_group, 0, 0,
  1657. "%d free blocks as per "
  1658. "group info. But bitmap says 0",
  1659. free);
  1660. break;
  1661. }
  1662. mb_find_extent(e4b, 0, i, ac->ac_g_ex.fe_len, &ex);
  1663. BUG_ON(ex.fe_len <= 0);
  1664. if (free < ex.fe_len) {
  1665. ext4_grp_locked_error(sb, e4b->bd_group, 0, 0,
  1666. "%d free blocks as per "
  1667. "group info. But got %d blocks",
  1668. free, ex.fe_len);
  1669. /*
  1670. * The number of free blocks differs. This mostly
  1671. * indicate that the bitmap is corrupt. So exit
  1672. * without claiming the space.
  1673. */
  1674. break;
  1675. }
  1676. ext4_mb_measure_extent(ac, &ex, e4b);
  1677. i += ex.fe_len;
  1678. free -= ex.fe_len;
  1679. }
  1680. ext4_mb_check_limits(ac, e4b, 1);
  1681. }
  1682. /*
  1683. * This is a special case for storages like raid5
  1684. * we try to find stripe-aligned chunks for stripe-size-multiple requests
  1685. */
  1686. static noinline_for_stack
  1687. void ext4_mb_scan_aligned(struct ext4_allocation_context *ac,
  1688. struct ext4_buddy *e4b)
  1689. {
  1690. struct super_block *sb = ac->ac_sb;
  1691. struct ext4_sb_info *sbi = EXT4_SB(sb);
  1692. void *bitmap = EXT4_MB_BITMAP(e4b);
  1693. struct ext4_free_extent ex;
  1694. ext4_fsblk_t first_group_block;
  1695. ext4_fsblk_t a;
  1696. ext4_grpblk_t i;
  1697. int max;
  1698. BUG_ON(sbi->s_stripe == 0);
  1699. /* find first stripe-aligned block in group */
  1700. first_group_block = ext4_group_first_block_no(sb, e4b->bd_group);
  1701. a = first_group_block + sbi->s_stripe - 1;
  1702. do_div(a, sbi->s_stripe);
  1703. i = (a * sbi->s_stripe) - first_group_block;
  1704. while (i < EXT4_BLOCKS_PER_GROUP(sb)) {
  1705. if (!mb_test_bit(i, bitmap)) {
  1706. max = mb_find_extent(e4b, 0, i, sbi->s_stripe, &ex);
  1707. if (max >= sbi->s_stripe) {
  1708. ac->ac_found++;
  1709. ac->ac_b_ex = ex;
  1710. ext4_mb_use_best_found(ac, e4b);
  1711. break;
  1712. }
  1713. }
  1714. i += sbi->s_stripe;
  1715. }
  1716. }
  1717. /* This is now called BEFORE we load the buddy bitmap. */
  1718. static int ext4_mb_good_group(struct ext4_allocation_context *ac,
  1719. ext4_group_t group, int cr)
  1720. {
  1721. unsigned free, fragments;
  1722. int flex_size = ext4_flex_bg_size(EXT4_SB(ac->ac_sb));
  1723. struct ext4_group_info *grp = ext4_get_group_info(ac->ac_sb, group);
  1724. BUG_ON(cr < 0 || cr >= 4);
  1725. /* We only do this if the grp has never been initialized */
  1726. if (unlikely(EXT4_MB_GRP_NEED_INIT(grp))) {
  1727. int ret = ext4_mb_init_group(ac->ac_sb, group);
  1728. if (ret)
  1729. return 0;
  1730. }
  1731. free = grp->bb_free;
  1732. fragments = grp->bb_fragments;
  1733. if (free == 0)
  1734. return 0;
  1735. if (fragments == 0)
  1736. return 0;
  1737. switch (cr) {
  1738. case 0:
  1739. BUG_ON(ac->ac_2order == 0);
  1740. if (grp->bb_largest_free_order < ac->ac_2order)
  1741. return 0;
  1742. /* Avoid using the first bg of a flexgroup for data files */
  1743. if ((ac->ac_flags & EXT4_MB_HINT_DATA) &&
  1744. (flex_size >= EXT4_FLEX_SIZE_DIR_ALLOC_SCHEME) &&
  1745. ((group % flex_size) == 0))
  1746. return 0;
  1747. return 1;
  1748. case 1:
  1749. if ((free / fragments) >= ac->ac_g_ex.fe_len)
  1750. return 1;
  1751. break;
  1752. case 2:
  1753. if (free >= ac->ac_g_ex.fe_len)
  1754. return 1;
  1755. break;
  1756. case 3:
  1757. return 1;
  1758. default:
  1759. BUG();
  1760. }
  1761. return 0;
  1762. }
  1763. static noinline_for_stack int
  1764. ext4_mb_regular_allocator(struct ext4_allocation_context *ac)
  1765. {
  1766. ext4_group_t ngroups, group, i;
  1767. int cr;
  1768. int err = 0;
  1769. struct ext4_sb_info *sbi;
  1770. struct super_block *sb;
  1771. struct ext4_buddy e4b;
  1772. sb = ac->ac_sb;
  1773. sbi = EXT4_SB(sb);
  1774. ngroups = ext4_get_groups_count(sb);
  1775. /* non-extent files are limited to low blocks/groups */
  1776. if (!(ext4_test_inode_flag(ac->ac_inode, EXT4_INODE_EXTENTS)))
  1777. ngroups = sbi->s_blockfile_groups;
  1778. BUG_ON(ac->ac_status == AC_STATUS_FOUND);
  1779. /* first, try the goal */
  1780. err = ext4_mb_find_by_goal(ac, &e4b);
  1781. if (err || ac->ac_status == AC_STATUS_FOUND)
  1782. goto out;
  1783. if (unlikely(ac->ac_flags & EXT4_MB_HINT_GOAL_ONLY))
  1784. goto out;
  1785. /*
  1786. * ac->ac2_order is set only if the fe_len is a power of 2
  1787. * if ac2_order is set we also set criteria to 0 so that we
  1788. * try exact allocation using buddy.
  1789. */
  1790. i = fls(ac->ac_g_ex.fe_len);
  1791. ac->ac_2order = 0;
  1792. /*
  1793. * We search using buddy data only if the order of the request
  1794. * is greater than equal to the sbi_s_mb_order2_reqs
  1795. * You can tune it via /sys/fs/ext4/<partition>/mb_order2_req
  1796. */
  1797. if (i >= sbi->s_mb_order2_reqs) {
  1798. /*
  1799. * This should tell if fe_len is exactly power of 2
  1800. */
  1801. if ((ac->ac_g_ex.fe_len & (~(1 << (i - 1)))) == 0)
  1802. ac->ac_2order = i - 1;
  1803. }
  1804. /* if stream allocation is enabled, use global goal */
  1805. if (ac->ac_flags & EXT4_MB_STREAM_ALLOC) {
  1806. /* TBD: may be hot point */
  1807. spin_lock(&sbi->s_md_lock);
  1808. ac->ac_g_ex.fe_group = sbi->s_mb_last_group;
  1809. ac->ac_g_ex.fe_start = sbi->s_mb_last_start;
  1810. spin_unlock(&sbi->s_md_lock);
  1811. }
  1812. /* Let's just scan groups to find more-less suitable blocks */
  1813. cr = ac->ac_2order ? 0 : 1;
  1814. /*
  1815. * cr == 0 try to get exact allocation,
  1816. * cr == 3 try to get anything
  1817. */
  1818. repeat:
  1819. for (; cr < 4 && ac->ac_status == AC_STATUS_CONTINUE; cr++) {
  1820. ac->ac_criteria = cr;
  1821. /*
  1822. * searching for the right group start
  1823. * from the goal value specified
  1824. */
  1825. group = ac->ac_g_ex.fe_group;
  1826. for (i = 0; i < ngroups; group++, i++) {
  1827. if (group == ngroups)
  1828. group = 0;
  1829. /* This now checks without needing the buddy page */
  1830. if (!ext4_mb_good_group(ac, group, cr))
  1831. continue;
  1832. err = ext4_mb_load_buddy(sb, group, &e4b);
  1833. if (err)
  1834. goto out;
  1835. ext4_lock_group(sb, group);
  1836. /*
  1837. * We need to check again after locking the
  1838. * block group
  1839. */
  1840. if (!ext4_mb_good_group(ac, group, cr)) {
  1841. ext4_unlock_group(sb, group);
  1842. ext4_mb_unload_buddy(&e4b);
  1843. continue;
  1844. }
  1845. ac->ac_groups_scanned++;
  1846. if (cr == 0)
  1847. ext4_mb_simple_scan_group(ac, &e4b);
  1848. else if (cr == 1 && sbi->s_stripe &&
  1849. !(ac->ac_g_ex.fe_len % sbi->s_stripe))
  1850. ext4_mb_scan_aligned(ac, &e4b);
  1851. else
  1852. ext4_mb_complex_scan_group(ac, &e4b);
  1853. ext4_unlock_group(sb, group);
  1854. ext4_mb_unload_buddy(&e4b);
  1855. if (ac->ac_status != AC_STATUS_CONTINUE)
  1856. break;
  1857. }
  1858. }
  1859. if (ac->ac_b_ex.fe_len > 0 && ac->ac_status != AC_STATUS_FOUND &&
  1860. !(ac->ac_flags & EXT4_MB_HINT_FIRST)) {
  1861. /*
  1862. * We've been searching too long. Let's try to allocate
  1863. * the best chunk we've found so far
  1864. */
  1865. ext4_mb_try_best_found(ac, &e4b);
  1866. if (ac->ac_status != AC_STATUS_FOUND) {
  1867. /*
  1868. * Someone more lucky has already allocated it.
  1869. * The only thing we can do is just take first
  1870. * found block(s)
  1871. printk(KERN_DEBUG "EXT4-fs: someone won our chunk\n");
  1872. */
  1873. ac->ac_b_ex.fe_group = 0;
  1874. ac->ac_b_ex.fe_start = 0;
  1875. ac->ac_b_ex.fe_len = 0;
  1876. ac->ac_status = AC_STATUS_CONTINUE;
  1877. ac->ac_flags |= EXT4_MB_HINT_FIRST;
  1878. cr = 3;
  1879. atomic_inc(&sbi->s_mb_lost_chunks);
  1880. goto repeat;
  1881. }
  1882. }
  1883. out:
  1884. return err;
  1885. }
  1886. static void *ext4_mb_seq_groups_start(struct seq_file *seq, loff_t *pos)
  1887. {
  1888. struct super_block *sb = seq->private;
  1889. ext4_group_t group;
  1890. if (*pos < 0 || *pos >= ext4_get_groups_count(sb))
  1891. return NULL;
  1892. group = *pos + 1;
  1893. return (void *) ((unsigned long) group);
  1894. }
  1895. static void *ext4_mb_seq_groups_next(struct seq_file *seq, void *v, loff_t *pos)
  1896. {
  1897. struct super_block *sb = seq->private;
  1898. ext4_group_t group;
  1899. ++*pos;
  1900. if (*pos < 0 || *pos >= ext4_get_groups_count(sb))
  1901. return NULL;
  1902. group = *pos + 1;
  1903. return (void *) ((unsigned long) group);
  1904. }
  1905. static int ext4_mb_seq_groups_show(struct seq_file *seq, void *v)
  1906. {
  1907. struct super_block *sb = seq->private;
  1908. ext4_group_t group = (ext4_group_t) ((unsigned long) v);
  1909. int i;
  1910. int err;
  1911. struct ext4_buddy e4b;
  1912. struct sg {
  1913. struct ext4_group_info info;
  1914. ext4_grpblk_t counters[16];
  1915. } sg;
  1916. group--;
  1917. if (group == 0)
  1918. seq_printf(seq, "#%-5s: %-5s %-5s %-5s "
  1919. "[ %-5s %-5s %-5s %-5s %-5s %-5s %-5s "
  1920. "%-5s %-5s %-5s %-5s %-5s %-5s %-5s ]\n",
  1921. "group", "free", "frags", "first",
  1922. "2^0", "2^1", "2^2", "2^3", "2^4", "2^5", "2^6",
  1923. "2^7", "2^8", "2^9", "2^10", "2^11", "2^12", "2^13");
  1924. i = (sb->s_blocksize_bits + 2) * sizeof(sg.info.bb_counters[0]) +
  1925. sizeof(struct ext4_group_info);
  1926. err = ext4_mb_load_buddy(sb, group, &e4b);
  1927. if (err) {
  1928. seq_printf(seq, "#%-5u: I/O error\n", group);
  1929. return 0;
  1930. }
  1931. ext4_lock_group(sb, group);
  1932. memcpy(&sg, ext4_get_group_info(sb, group), i);
  1933. ext4_unlock_group(sb, group);
  1934. ext4_mb_unload_buddy(&e4b);
  1935. seq_printf(seq, "#%-5u: %-5u %-5u %-5u [", group, sg.info.bb_free,
  1936. sg.info.bb_fragments, sg.info.bb_first_free);
  1937. for (i = 0; i <= 13; i++)
  1938. seq_printf(seq, " %-5u", i <= sb->s_blocksize_bits + 1 ?
  1939. sg.info.bb_counters[i] : 0);
  1940. seq_printf(seq, " ]\n");
  1941. return 0;
  1942. }
  1943. static void ext4_mb_seq_groups_stop(struct seq_file *seq, void *v)
  1944. {
  1945. }
  1946. static const struct seq_operations ext4_mb_seq_groups_ops = {
  1947. .start = ext4_mb_seq_groups_start,
  1948. .next = ext4_mb_seq_groups_next,
  1949. .stop = ext4_mb_seq_groups_stop,
  1950. .show = ext4_mb_seq_groups_show,
  1951. };
  1952. static int ext4_mb_seq_groups_open(struct inode *inode, struct file *file)
  1953. {
  1954. struct super_block *sb = PDE(inode)->data;
  1955. int rc;
  1956. rc = seq_open(file, &ext4_mb_seq_groups_ops);
  1957. if (rc == 0) {
  1958. struct seq_file *m = file->private_data;
  1959. m->private = sb;
  1960. }
  1961. return rc;
  1962. }
  1963. static const struct file_operations ext4_mb_seq_groups_fops = {
  1964. .owner = THIS_MODULE,
  1965. .open = ext4_mb_seq_groups_open,
  1966. .read = seq_read,
  1967. .llseek = seq_lseek,
  1968. .release = seq_release,
  1969. };
  1970. static struct kmem_cache *get_groupinfo_cache(int blocksize_bits)
  1971. {
  1972. int cache_index = blocksize_bits - EXT4_MIN_BLOCK_LOG_SIZE;
  1973. struct kmem_cache *cachep = ext4_groupinfo_caches[cache_index];
  1974. BUG_ON(!cachep);
  1975. return cachep;
  1976. }
  1977. /* Create and initialize ext4_group_info data for the given group. */
  1978. int ext4_mb_add_groupinfo(struct super_block *sb, ext4_group_t group,
  1979. struct ext4_group_desc *desc)
  1980. {
  1981. int i;
  1982. int metalen = 0;
  1983. struct ext4_sb_info *sbi = EXT4_SB(sb);
  1984. struct ext4_group_info **meta_group_info;
  1985. struct kmem_cache *cachep = get_groupinfo_cache(sb->s_blocksize_bits);
  1986. /*
  1987. * First check if this group is the first of a reserved block.
  1988. * If it's true, we have to allocate a new table of pointers
  1989. * to ext4_group_info structures
  1990. */
  1991. if (group % EXT4_DESC_PER_BLOCK(sb) == 0) {
  1992. metalen = sizeof(*meta_group_info) <<
  1993. EXT4_DESC_PER_BLOCK_BITS(sb);
  1994. meta_group_info = kmalloc(metalen, GFP_KERNEL);
  1995. if (meta_group_info == NULL) {
  1996. printk(KERN_ERR "EXT4-fs: can't allocate mem for a "
  1997. "buddy group\n");
  1998. goto exit_meta_group_info;
  1999. }
  2000. sbi->s_group_info[group >> EXT4_DESC_PER_BLOCK_BITS(sb)] =
  2001. meta_group_info;
  2002. }
  2003. meta_group_info =
  2004. sbi->s_group_info[group >> EXT4_DESC_PER_BLOCK_BITS(sb)];
  2005. i = group & (EXT4_DESC_PER_BLOCK(sb) - 1);
  2006. meta_group_info[i] = kmem_cache_alloc(cachep, GFP_KERNEL);
  2007. if (meta_group_info[i] == NULL) {
  2008. printk(KERN_ERR "EXT4-fs: can't allocate buddy mem\n");
  2009. goto exit_group_info;
  2010. }
  2011. memset(meta_group_info[i], 0, kmem_cache_size(cachep));
  2012. set_bit(EXT4_GROUP_INFO_NEED_INIT_BIT,
  2013. &(meta_group_info[i]->bb_state));
  2014. /*
  2015. * initialize bb_free to be able to skip
  2016. * empty groups without initialization
  2017. */
  2018. if (desc->bg_flags & cpu_to_le16(EXT4_BG_BLOCK_UNINIT)) {
  2019. meta_group_info[i]->bb_free =
  2020. ext4_free_blocks_after_init(sb, group, desc);
  2021. } else {
  2022. meta_group_info[i]->bb_free =
  2023. ext4_free_blks_count(sb, desc);
  2024. }
  2025. INIT_LIST_HEAD(&meta_group_info[i]->bb_prealloc_list);
  2026. init_rwsem(&meta_group_info[i]->alloc_sem);
  2027. meta_group_info[i]->bb_free_root = RB_ROOT;
  2028. meta_group_info[i]->bb_largest_free_order = -1; /* uninit */
  2029. #ifdef DOUBLE_CHECK
  2030. {
  2031. struct buffer_head *bh;
  2032. meta_group_info[i]->bb_bitmap =
  2033. kmalloc(sb->s_blocksize, GFP_KERNEL);
  2034. BUG_ON(meta_group_info[i]->bb_bitmap == NULL);
  2035. bh = ext4_read_block_bitmap(sb, group);
  2036. BUG_ON(bh == NULL);
  2037. memcpy(meta_group_info[i]->bb_bitmap, bh->b_data,
  2038. sb->s_blocksize);
  2039. put_bh(bh);
  2040. }
  2041. #endif
  2042. return 0;
  2043. exit_group_info:
  2044. /* If a meta_group_info table has been allocated, release it now */
  2045. if (group % EXT4_DESC_PER_BLOCK(sb) == 0)
  2046. kfree(sbi->s_group_info[group >> EXT4_DESC_PER_BLOCK_BITS(sb)]);
  2047. exit_meta_group_info:
  2048. return -ENOMEM;
  2049. } /* ext4_mb_add_groupinfo */
  2050. static int ext4_mb_init_backend(struct super_block *sb)
  2051. {
  2052. ext4_group_t ngroups = ext4_get_groups_count(sb);
  2053. ext4_group_t i;
  2054. struct ext4_sb_info *sbi = EXT4_SB(sb);
  2055. struct ext4_super_block *es = sbi->s_es;
  2056. int num_meta_group_infos;
  2057. int num_meta_group_infos_max;
  2058. int array_size;
  2059. struct ext4_group_desc *desc;
  2060. struct kmem_cache *cachep;
  2061. /* This is the number of blocks used by GDT */
  2062. num_meta_group_infos = (ngroups + EXT4_DESC_PER_BLOCK(sb) -
  2063. 1) >> EXT4_DESC_PER_BLOCK_BITS(sb);
  2064. /*
  2065. * This is the total number of blocks used by GDT including
  2066. * the number of reserved blocks for GDT.
  2067. * The s_group_info array is allocated with this value
  2068. * to allow a clean online resize without a complex
  2069. * manipulation of pointer.
  2070. * The drawback is the unused memory when no resize
  2071. * occurs but it's very low in terms of pages
  2072. * (see comments below)
  2073. * Need to handle this properly when META_BG resizing is allowed
  2074. */
  2075. num_meta_group_infos_max = num_meta_group_infos +
  2076. le16_to_cpu(es->s_reserved_gdt_blocks);
  2077. /*
  2078. * array_size is the size of s_group_info array. We round it
  2079. * to the next power of two because this approximation is done
  2080. * internally by kmalloc so we can have some more memory
  2081. * for free here (e.g. may be used for META_BG resize).
  2082. */
  2083. array_size = 1;
  2084. while (array_size < sizeof(*sbi->s_group_info) *
  2085. num_meta_group_infos_max)
  2086. array_size = array_size << 1;
  2087. /* An 8TB filesystem with 64-bit pointers requires a 4096 byte
  2088. * kmalloc. A 128kb malloc should suffice for a 256TB filesystem.
  2089. * So a two level scheme suffices for now. */
  2090. sbi->s_group_info = kzalloc(array_size, GFP_KERNEL);
  2091. if (sbi->s_group_info == NULL) {
  2092. printk(KERN_ERR "EXT4-fs: can't allocate buddy meta group\n");
  2093. return -ENOMEM;
  2094. }
  2095. sbi->s_buddy_cache = new_inode(sb);
  2096. if (sbi->s_buddy_cache == NULL) {
  2097. printk(KERN_ERR "EXT4-fs: can't get new inode\n");
  2098. goto err_freesgi;
  2099. }
  2100. sbi->s_buddy_cache->i_ino = get_next_ino();
  2101. EXT4_I(sbi->s_buddy_cache)->i_disksize = 0;
  2102. for (i = 0; i < ngroups; i++) {
  2103. desc = ext4_get_group_desc(sb, i, NULL);
  2104. if (desc == NULL) {
  2105. printk(KERN_ERR
  2106. "EXT4-fs: can't read descriptor %u\n", i);
  2107. goto err_freebuddy;
  2108. }
  2109. if (ext4_mb_add_groupinfo(sb, i, desc) != 0)
  2110. goto err_freebuddy;
  2111. }
  2112. return 0;
  2113. err_freebuddy:
  2114. cachep = get_groupinfo_cache(sb->s_blocksize_bits);
  2115. while (i-- > 0)
  2116. kmem_cache_free(cachep, ext4_get_group_info(sb, i));
  2117. i = num_meta_group_infos;
  2118. while (i-- > 0)
  2119. kfree(sbi->s_group_info[i]);
  2120. iput(sbi->s_buddy_cache);
  2121. err_freesgi:
  2122. kfree(sbi->s_group_info);
  2123. return -ENOMEM;
  2124. }
  2125. static void ext4_groupinfo_destroy_slabs(void)
  2126. {
  2127. int i;
  2128. for (i = 0; i < NR_GRPINFO_CACHES; i++) {
  2129. if (ext4_groupinfo_caches[i])
  2130. kmem_cache_destroy(ext4_groupinfo_caches[i]);
  2131. ext4_groupinfo_caches[i] = NULL;
  2132. }
  2133. }
  2134. static int ext4_groupinfo_create_slab(size_t size)
  2135. {
  2136. static DEFINE_MUTEX(ext4_grpinfo_slab_create_mutex);
  2137. int slab_size;
  2138. int blocksize_bits = order_base_2(size);
  2139. int cache_index = blocksize_bits - EXT4_MIN_BLOCK_LOG_SIZE;
  2140. struct kmem_cache *cachep;
  2141. if (cache_index >= NR_GRPINFO_CACHES)
  2142. return -EINVAL;
  2143. if (unlikely(cache_index < 0))
  2144. cache_index = 0;
  2145. mutex_lock(&ext4_grpinfo_slab_create_mutex);
  2146. if (ext4_groupinfo_caches[cache_index]) {
  2147. mutex_unlock(&ext4_grpinfo_slab_create_mutex);
  2148. return 0; /* Already created */
  2149. }
  2150. slab_size = offsetof(struct ext4_group_info,
  2151. bb_counters[blocksize_bits + 2]);
  2152. cachep = kmem_cache_create(ext4_groupinfo_slab_names[cache_index],
  2153. slab_size, 0, SLAB_RECLAIM_ACCOUNT,
  2154. NULL);
  2155. mutex_unlock(&ext4_grpinfo_slab_create_mutex);
  2156. if (!cachep) {
  2157. printk(KERN_EMERG "EXT4: no memory for groupinfo slab cache\n");
  2158. return -ENOMEM;
  2159. }
  2160. ext4_groupinfo_caches[cache_index] = cachep;
  2161. return 0;
  2162. }
  2163. int ext4_mb_init(struct super_block *sb, int needs_recovery)
  2164. {
  2165. struct ext4_sb_info *sbi = EXT4_SB(sb);
  2166. unsigned i, j;
  2167. unsigned offset;
  2168. unsigned max;
  2169. int ret;
  2170. i = (sb->s_blocksize_bits + 2) * sizeof(*sbi->s_mb_offsets);
  2171. sbi->s_mb_offsets = kmalloc(i, GFP_KERNEL);
  2172. if (sbi->s_mb_offsets == NULL) {
  2173. ret = -ENOMEM;
  2174. goto out;
  2175. }
  2176. i = (sb->s_blocksize_bits + 2) * sizeof(*sbi->s_mb_maxs);
  2177. sbi->s_mb_maxs = kmalloc(i, GFP_KERNEL);
  2178. if (sbi->s_mb_maxs == NULL) {
  2179. ret = -ENOMEM;
  2180. goto out;
  2181. }
  2182. ret = ext4_groupinfo_create_slab(sb->s_blocksize);
  2183. if (ret < 0)
  2184. goto out;
  2185. /* order 0 is regular bitmap */
  2186. sbi->s_mb_maxs[0] = sb->s_blocksize << 3;
  2187. sbi->s_mb_offsets[0] = 0;
  2188. i = 1;
  2189. offset = 0;
  2190. max = sb->s_blocksize << 2;
  2191. do {
  2192. sbi->s_mb_offsets[i] = offset;
  2193. sbi->s_mb_maxs[i] = max;
  2194. offset += 1 << (sb->s_blocksize_bits - i);
  2195. max = max >> 1;
  2196. i++;
  2197. } while (i <= sb->s_blocksize_bits + 1);
  2198. /* init file for buddy data */
  2199. ret = ext4_mb_init_backend(sb);
  2200. if (ret != 0) {
  2201. goto out;
  2202. }
  2203. spin_lock_init(&sbi->s_md_lock);
  2204. spin_lock_init(&sbi->s_bal_lock);
  2205. sbi->s_mb_max_to_scan = MB_DEFAULT_MAX_TO_SCAN;
  2206. sbi->s_mb_min_to_scan = MB_DEFAULT_MIN_TO_SCAN;
  2207. sbi->s_mb_stats = MB_DEFAULT_STATS;
  2208. sbi->s_mb_stream_request = MB_DEFAULT_STREAM_THRESHOLD;
  2209. sbi->s_mb_order2_reqs = MB_DEFAULT_ORDER2_REQS;
  2210. sbi->s_mb_group_prealloc = MB_DEFAULT_GROUP_PREALLOC;
  2211. sbi->s_locality_groups = alloc_percpu(struct ext4_locality_group);
  2212. if (sbi->s_locality_groups == NULL) {
  2213. ret = -ENOMEM;
  2214. goto out;
  2215. }
  2216. for_each_possible_cpu(i) {
  2217. struct ext4_locality_group *lg;
  2218. lg = per_cpu_ptr(sbi->s_locality_groups, i);
  2219. mutex_init(&lg->lg_mutex);
  2220. for (j = 0; j < PREALLOC_TB_SIZE; j++)
  2221. INIT_LIST_HEAD(&lg->lg_prealloc_list[j]);
  2222. spin_lock_init(&lg->lg_prealloc_lock);
  2223. }
  2224. if (sbi->s_proc)
  2225. proc_create_data("mb_groups", S_IRUGO, sbi->s_proc,
  2226. &ext4_mb_seq_groups_fops, sb);
  2227. if (sbi->s_journal)
  2228. sbi->s_journal->j_commit_callback = release_blocks_on_commit;
  2229. out:
  2230. if (ret) {
  2231. kfree(sbi->s_mb_offsets);
  2232. kfree(sbi->s_mb_maxs);
  2233. }
  2234. return ret;
  2235. }
  2236. /* need to called with the ext4 group lock held */
  2237. static void ext4_mb_cleanup_pa(struct ext4_group_info *grp)
  2238. {
  2239. struct ext4_prealloc_space *pa;
  2240. struct list_head *cur, *tmp;
  2241. int count = 0;
  2242. list_for_each_safe(cur, tmp, &grp->bb_prealloc_list) {
  2243. pa = list_entry(cur, struct ext4_prealloc_space, pa_group_list);
  2244. list_del(&pa->pa_group_list);
  2245. count++;
  2246. kmem_cache_free(ext4_pspace_cachep, pa);
  2247. }
  2248. if (count)
  2249. mb_debug(1, "mballoc: %u PAs left\n", count);
  2250. }
  2251. int ext4_mb_release(struct super_block *sb)
  2252. {
  2253. ext4_group_t ngroups = ext4_get_groups_count(sb);
  2254. ext4_group_t i;
  2255. int num_meta_group_infos;
  2256. struct ext4_group_info *grinfo;
  2257. struct ext4_sb_info *sbi = EXT4_SB(sb);
  2258. struct kmem_cache *cachep = get_groupinfo_cache(sb->s_blocksize_bits);
  2259. if (sbi->s_group_info) {
  2260. for (i = 0; i < ngroups; i++) {
  2261. grinfo = ext4_get_group_info(sb, i);
  2262. #ifdef DOUBLE_CHECK
  2263. kfree(grinfo->bb_bitmap);
  2264. #endif
  2265. ext4_lock_group(sb, i);
  2266. ext4_mb_cleanup_pa(grinfo);
  2267. ext4_unlock_group(sb, i);
  2268. kmem_cache_free(cachep, grinfo);
  2269. }
  2270. num_meta_group_infos = (ngroups +
  2271. EXT4_DESC_PER_BLOCK(sb) - 1) >>
  2272. EXT4_DESC_PER_BLOCK_BITS(sb);
  2273. for (i = 0; i < num_meta_group_infos; i++)
  2274. kfree(sbi->s_group_info[i]);
  2275. kfree(sbi->s_group_info);
  2276. }
  2277. kfree(sbi->s_mb_offsets);
  2278. kfree(sbi->s_mb_maxs);
  2279. if (sbi->s_buddy_cache)
  2280. iput(sbi->s_buddy_cache);
  2281. if (sbi->s_mb_stats) {
  2282. printk(KERN_INFO
  2283. "EXT4-fs: mballoc: %u blocks %u reqs (%u success)\n",
  2284. atomic_read(&sbi->s_bal_allocated),
  2285. atomic_read(&sbi->s_bal_reqs),
  2286. atomic_read(&sbi->s_bal_success));
  2287. printk(KERN_INFO
  2288. "EXT4-fs: mballoc: %u extents scanned, %u goal hits, "
  2289. "%u 2^N hits, %u breaks, %u lost\n",
  2290. atomic_read(&sbi->s_bal_ex_scanned),
  2291. atomic_read(&sbi->s_bal_goals),
  2292. atomic_read(&sbi->s_bal_2orders),
  2293. atomic_read(&sbi->s_bal_breaks),
  2294. atomic_read(&sbi->s_mb_lost_chunks));
  2295. printk(KERN_INFO
  2296. "EXT4-fs: mballoc: %lu generated and it took %Lu\n",
  2297. sbi->s_mb_buddies_generated++,
  2298. sbi->s_mb_generation_time);
  2299. printk(KERN_INFO
  2300. "EXT4-fs: mballoc: %u preallocated, %u discarded\n",
  2301. atomic_read(&sbi->s_mb_preallocated),
  2302. atomic_read(&sbi->s_mb_discarded));
  2303. }
  2304. free_percpu(sbi->s_locality_groups);
  2305. if (sbi->s_proc)
  2306. remove_proc_entry("mb_groups", sbi->s_proc);
  2307. return 0;
  2308. }
  2309. static inline int ext4_issue_discard(struct super_block *sb,
  2310. ext4_group_t block_group, ext4_grpblk_t block, int count)
  2311. {
  2312. ext4_fsblk_t discard_block;
  2313. discard_block = block + ext4_group_first_block_no(sb, block_group);
  2314. trace_ext4_discard_blocks(sb,
  2315. (unsigned long long) discard_block, count);
  2316. return sb_issue_discard(sb, discard_block, count, GFP_NOFS, 0);
  2317. }
  2318. /*
  2319. * This function is called by the jbd2 layer once the commit has finished,
  2320. * so we know we can free the blocks that were released with that commit.
  2321. */
  2322. static void release_blocks_on_commit(journal_t *journal, transaction_t *txn)
  2323. {
  2324. struct super_block *sb = journal->j_private;
  2325. struct ext4_buddy e4b;
  2326. struct ext4_group_info *db;
  2327. int err, count = 0, count2 = 0;
  2328. struct ext4_free_data *entry;
  2329. struct list_head *l, *ltmp;
  2330. list_for_each_safe(l, ltmp, &txn->t_private_list) {
  2331. entry = list_entry(l, struct ext4_free_data, list);
  2332. mb_debug(1, "gonna free %u blocks in group %u (0x%p):",
  2333. entry->count, entry->group, entry);
  2334. if (test_opt(sb, DISCARD))
  2335. ext4_issue_discard(sb, entry->group,
  2336. entry->start_blk, entry->count);
  2337. err = ext4_mb_load_buddy(sb, entry->group, &e4b);
  2338. /* we expect to find existing buddy because it's pinned */
  2339. BUG_ON(err != 0);
  2340. db = e4b.bd_info;
  2341. /* there are blocks to put in buddy to make them really free */
  2342. count += entry->count;
  2343. count2++;
  2344. ext4_lock_group(sb, entry->group);
  2345. /* Take it out of per group rb tree */
  2346. rb_erase(&entry->node, &(db->bb_free_root));
  2347. mb_free_blocks(NULL, &e4b, entry->start_blk, entry->count);
  2348. if (!db->bb_free_root.rb_node) {
  2349. /* No more items in the per group rb tree
  2350. * balance refcounts from ext4_mb_free_metadata()
  2351. */
  2352. page_cache_release(e4b.bd_buddy_page);
  2353. page_cache_release(e4b.bd_bitmap_page);
  2354. }
  2355. ext4_unlock_group(sb, entry->group);
  2356. kmem_cache_free(ext4_free_ext_cachep, entry);
  2357. ext4_mb_unload_buddy(&e4b);
  2358. }
  2359. mb_debug(1, "freed %u blocks in %u structures\n", count, count2);
  2360. }
  2361. #ifdef CONFIG_EXT4_DEBUG
  2362. u8 mb_enable_debug __read_mostly;
  2363. static struct dentry *debugfs_dir;
  2364. static struct dentry *debugfs_debug;
  2365. static void __init ext4_create_debugfs_entry(void)
  2366. {
  2367. debugfs_dir = debugfs_create_dir("ext4", NULL);
  2368. if (debugfs_dir)
  2369. debugfs_debug = debugfs_create_u8("mballoc-debug",
  2370. S_IRUGO | S_IWUSR,
  2371. debugfs_dir,
  2372. &mb_enable_debug);
  2373. }
  2374. static void ext4_remove_debugfs_entry(void)
  2375. {
  2376. debugfs_remove(debugfs_debug);
  2377. debugfs_remove(debugfs_dir);
  2378. }
  2379. #else
  2380. static void __init ext4_create_debugfs_entry(void)
  2381. {
  2382. }
  2383. static void ext4_remove_debugfs_entry(void)
  2384. {
  2385. }
  2386. #endif
  2387. int __init ext4_init_mballoc(void)
  2388. {
  2389. ext4_pspace_cachep = KMEM_CACHE(ext4_prealloc_space,
  2390. SLAB_RECLAIM_ACCOUNT);
  2391. if (ext4_pspace_cachep == NULL)
  2392. return -ENOMEM;
  2393. ext4_ac_cachep = KMEM_CACHE(ext4_allocation_context,
  2394. SLAB_RECLAIM_ACCOUNT);
  2395. if (ext4_ac_cachep == NULL) {
  2396. kmem_cache_destroy(ext4_pspace_cachep);
  2397. return -ENOMEM;
  2398. }
  2399. ext4_free_ext_cachep = KMEM_CACHE(ext4_free_data,
  2400. SLAB_RECLAIM_ACCOUNT);
  2401. if (ext4_free_ext_cachep == NULL) {
  2402. kmem_cache_destroy(ext4_pspace_cachep);
  2403. kmem_cache_destroy(ext4_ac_cachep);
  2404. return -ENOMEM;
  2405. }
  2406. ext4_create_debugfs_entry();
  2407. return 0;
  2408. }
  2409. void ext4_exit_mballoc(void)
  2410. {
  2411. /*
  2412. * Wait for completion of call_rcu()'s on ext4_pspace_cachep
  2413. * before destroying the slab cache.
  2414. */
  2415. rcu_barrier();
  2416. kmem_cache_destroy(ext4_pspace_cachep);
  2417. kmem_cache_destroy(ext4_ac_cachep);
  2418. kmem_cache_destroy(ext4_free_ext_cachep);
  2419. ext4_groupinfo_destroy_slabs();
  2420. ext4_remove_debugfs_entry();
  2421. }
  2422. /*
  2423. * Check quota and mark chosen space (ac->ac_b_ex) non-free in bitmaps
  2424. * Returns 0 if success or error code
  2425. */
  2426. static noinline_for_stack int
  2427. ext4_mb_mark_diskspace_used(struct ext4_allocation_context *ac,
  2428. handle_t *handle, unsigned int reserv_blks)
  2429. {
  2430. struct buffer_head *bitmap_bh = NULL;
  2431. struct ext4_group_desc *gdp;
  2432. struct buffer_head *gdp_bh;
  2433. struct ext4_sb_info *sbi;
  2434. struct super_block *sb;
  2435. ext4_fsblk_t block;
  2436. int err, len;
  2437. BUG_ON(ac->ac_status != AC_STATUS_FOUND);
  2438. BUG_ON(ac->ac_b_ex.fe_len <= 0);
  2439. sb = ac->ac_sb;
  2440. sbi = EXT4_SB(sb);
  2441. err = -EIO;
  2442. bitmap_bh = ext4_read_block_bitmap(sb, ac->ac_b_ex.fe_group);
  2443. if (!bitmap_bh)
  2444. goto out_err;
  2445. err = ext4_journal_get_write_access(handle, bitmap_bh);
  2446. if (err)
  2447. goto out_err;
  2448. err = -EIO;
  2449. gdp = ext4_get_group_desc(sb, ac->ac_b_ex.fe_group, &gdp_bh);
  2450. if (!gdp)
  2451. goto out_err;
  2452. ext4_debug("using block group %u(%d)\n", ac->ac_b_ex.fe_group,
  2453. ext4_free_blks_count(sb, gdp));
  2454. err = ext4_journal_get_write_access(handle, gdp_bh);
  2455. if (err)
  2456. goto out_err;
  2457. block = ext4_grp_offs_to_block(sb, &ac->ac_b_ex);
  2458. len = ac->ac_b_ex.fe_len;
  2459. if (!ext4_data_block_valid(sbi, block, len)) {
  2460. ext4_error(sb, "Allocating blocks %llu-%llu which overlap "
  2461. "fs metadata\n", block, block+len);
  2462. /* File system mounted not to panic on error
  2463. * Fix the bitmap and repeat the block allocation
  2464. * We leak some of the blocks here.
  2465. */
  2466. ext4_lock_group(sb, ac->ac_b_ex.fe_group);
  2467. mb_set_bits(bitmap_bh->b_data, ac->ac_b_ex.fe_start,
  2468. ac->ac_b_ex.fe_len);
  2469. ext4_unlock_group(sb, ac->ac_b_ex.fe_group);
  2470. err = ext4_handle_dirty_metadata(handle, NULL, bitmap_bh);
  2471. if (!err)
  2472. err = -EAGAIN;
  2473. goto out_err;
  2474. }
  2475. ext4_lock_group(sb, ac->ac_b_ex.fe_group);
  2476. #ifdef AGGRESSIVE_CHECK
  2477. {
  2478. int i;
  2479. for (i = 0; i < ac->ac_b_ex.fe_len; i++) {
  2480. BUG_ON(mb_test_bit(ac->ac_b_ex.fe_start + i,
  2481. bitmap_bh->b_data));
  2482. }
  2483. }
  2484. #endif
  2485. mb_set_bits(bitmap_bh->b_data, ac->ac_b_ex.fe_start,ac->ac_b_ex.fe_len);
  2486. if (gdp->bg_flags & cpu_to_le16(EXT4_BG_BLOCK_UNINIT)) {
  2487. gdp->bg_flags &= cpu_to_le16(~EXT4_BG_BLOCK_UNINIT);
  2488. ext4_free_blks_set(sb, gdp,
  2489. ext4_free_blocks_after_init(sb,
  2490. ac->ac_b_ex.fe_group, gdp));
  2491. }
  2492. len = ext4_free_blks_count(sb, gdp) - ac->ac_b_ex.fe_len;
  2493. ext4_free_blks_set(sb, gdp, len);
  2494. gdp->bg_checksum = ext4_group_desc_csum(sbi, ac->ac_b_ex.fe_group, gdp);
  2495. ext4_unlock_group(sb, ac->ac_b_ex.fe_group);
  2496. percpu_counter_sub(&sbi->s_freeblocks_counter, ac->ac_b_ex.fe_len);
  2497. /*
  2498. * Now reduce the dirty block count also. Should not go negative
  2499. */
  2500. if (!(ac->ac_flags & EXT4_MB_DELALLOC_RESERVED))
  2501. /* release all the reserved blocks if non delalloc */
  2502. percpu_counter_sub(&sbi->s_dirtyblocks_counter, reserv_blks);
  2503. if (sbi->s_log_groups_per_flex) {
  2504. ext4_group_t flex_group = ext4_flex_group(sbi,
  2505. ac->ac_b_ex.fe_group);
  2506. atomic_sub(ac->ac_b_ex.fe_len,
  2507. &sbi->s_flex_groups[flex_group].free_blocks);
  2508. }
  2509. err = ext4_handle_dirty_metadata(handle, NULL, bitmap_bh);
  2510. if (err)
  2511. goto out_err;
  2512. err = ext4_handle_dirty_metadata(handle, NULL, gdp_bh);
  2513. out_err:
  2514. ext4_mark_super_dirty(sb);
  2515. brelse(bitmap_bh);
  2516. return err;
  2517. }
  2518. /*
  2519. * here we normalize request for locality group
  2520. * Group request are normalized to s_strip size if we set the same via mount
  2521. * option. If not we set it to s_mb_group_prealloc which can be configured via
  2522. * /sys/fs/ext4/<partition>/mb_group_prealloc
  2523. *
  2524. * XXX: should we try to preallocate more than the group has now?
  2525. */
  2526. static void ext4_mb_normalize_group_request(struct ext4_allocation_context *ac)
  2527. {
  2528. struct super_block *sb = ac->ac_sb;
  2529. struct ext4_locality_group *lg = ac->ac_lg;
  2530. BUG_ON(lg == NULL);
  2531. if (EXT4_SB(sb)->s_stripe)
  2532. ac->ac_g_ex.fe_len = EXT4_SB(sb)->s_stripe;
  2533. else
  2534. ac->ac_g_ex.fe_len = EXT4_SB(sb)->s_mb_group_prealloc;
  2535. mb_debug(1, "#%u: goal %u blocks for locality group\n",
  2536. current->pid, ac->ac_g_ex.fe_len);
  2537. }
  2538. /*
  2539. * Normalization means making request better in terms of
  2540. * size and alignment
  2541. */
  2542. static noinline_for_stack void
  2543. ext4_mb_normalize_request(struct ext4_allocation_context *ac,
  2544. struct ext4_allocation_request *ar)
  2545. {
  2546. int bsbits, max;
  2547. ext4_lblk_t end;
  2548. loff_t size, orig_size, start_off;
  2549. ext4_lblk_t start;
  2550. struct ext4_inode_info *ei = EXT4_I(ac->ac_inode);
  2551. struct ext4_prealloc_space *pa;
  2552. /* do normalize only data requests, metadata requests
  2553. do not need preallocation */
  2554. if (!(ac->ac_flags & EXT4_MB_HINT_DATA))
  2555. return;
  2556. /* sometime caller may want exact blocks */
  2557. if (unlikely(ac->ac_flags & EXT4_MB_HINT_GOAL_ONLY))
  2558. return;
  2559. /* caller may indicate that preallocation isn't
  2560. * required (it's a tail, for example) */
  2561. if (ac->ac_flags & EXT4_MB_HINT_NOPREALLOC)
  2562. return;
  2563. if (ac->ac_flags & EXT4_MB_HINT_GROUP_ALLOC) {
  2564. ext4_mb_normalize_group_request(ac);
  2565. return ;
  2566. }
  2567. bsbits = ac->ac_sb->s_blocksize_bits;
  2568. /* first, let's learn actual file size
  2569. * given current request is allocated */
  2570. size = ac->ac_o_ex.fe_logical + ac->ac_o_ex.fe_len;
  2571. size = size << bsbits;
  2572. if (size < i_size_read(ac->ac_inode))
  2573. size = i_size_read(ac->ac_inode);
  2574. orig_size = size;
  2575. /* max size of free chunks */
  2576. max = 2 << bsbits;
  2577. #define NRL_CHECK_SIZE(req, size, max, chunk_size) \
  2578. (req <= (size) || max <= (chunk_size))
  2579. /* first, try to predict filesize */
  2580. /* XXX: should this table be tunable? */
  2581. start_off = 0;
  2582. if (size <= 16 * 1024) {
  2583. size = 16 * 1024;
  2584. } else if (size <= 32 * 1024) {
  2585. size = 32 * 1024;
  2586. } else if (size <= 64 * 1024) {
  2587. size = 64 * 1024;
  2588. } else if (size <= 128 * 1024) {
  2589. size = 128 * 1024;
  2590. } else if (size <= 256 * 1024) {
  2591. size = 256 * 1024;
  2592. } else if (size <= 512 * 1024) {
  2593. size = 512 * 1024;
  2594. } else if (size <= 1024 * 1024) {
  2595. size = 1024 * 1024;
  2596. } else if (NRL_CHECK_SIZE(size, 4 * 1024 * 1024, max, 2 * 1024)) {
  2597. start_off = ((loff_t)ac->ac_o_ex.fe_logical >>
  2598. (21 - bsbits)) << 21;
  2599. size = 2 * 1024 * 1024;
  2600. } else if (NRL_CHECK_SIZE(size, 8 * 1024 * 1024, max, 4 * 1024)) {
  2601. start_off = ((loff_t)ac->ac_o_ex.fe_logical >>
  2602. (22 - bsbits)) << 22;
  2603. size = 4 * 1024 * 1024;
  2604. } else if (NRL_CHECK_SIZE(ac->ac_o_ex.fe_len,
  2605. (8<<20)>>bsbits, max, 8 * 1024)) {
  2606. start_off = ((loff_t)ac->ac_o_ex.fe_logical >>
  2607. (23 - bsbits)) << 23;
  2608. size = 8 * 1024 * 1024;
  2609. } else {
  2610. start_off = (loff_t)ac->ac_o_ex.fe_logical << bsbits;
  2611. size = ac->ac_o_ex.fe_len << bsbits;
  2612. }
  2613. size = size >> bsbits;
  2614. start = start_off >> bsbits;
  2615. /* don't cover already allocated blocks in selected range */
  2616. if (ar->pleft && start <= ar->lleft) {
  2617. size -= ar->lleft + 1 - start;
  2618. start = ar->lleft + 1;
  2619. }
  2620. if (ar->pright && start + size - 1 >= ar->lright)
  2621. size -= start + size - ar->lright;
  2622. end = start + size;
  2623. /* check we don't cross already preallocated blocks */
  2624. rcu_read_lock();
  2625. list_for_each_entry_rcu(pa, &ei->i_prealloc_list, pa_inode_list) {
  2626. ext4_lblk_t pa_end;
  2627. if (pa->pa_deleted)
  2628. continue;
  2629. spin_lock(&pa->pa_lock);
  2630. if (pa->pa_deleted) {
  2631. spin_unlock(&pa->pa_lock);
  2632. continue;
  2633. }
  2634. pa_end = pa->pa_lstart + pa->pa_len;
  2635. /* PA must not overlap original request */
  2636. BUG_ON(!(ac->ac_o_ex.fe_logical >= pa_end ||
  2637. ac->ac_o_ex.fe_logical < pa->pa_lstart));
  2638. /* skip PAs this normalized request doesn't overlap with */
  2639. if (pa->pa_lstart >= end || pa_end <= start) {
  2640. spin_unlock(&pa->pa_lock);
  2641. continue;
  2642. }
  2643. BUG_ON(pa->pa_lstart <= start && pa_end >= end);
  2644. /* adjust start or end to be adjacent to this pa */
  2645. if (pa_end <= ac->ac_o_ex.fe_logical) {
  2646. BUG_ON(pa_end < start);
  2647. start = pa_end;
  2648. } else if (pa->pa_lstart > ac->ac_o_ex.fe_logical) {
  2649. BUG_ON(pa->pa_lstart > end);
  2650. end = pa->pa_lstart;
  2651. }
  2652. spin_unlock(&pa->pa_lock);
  2653. }
  2654. rcu_read_unlock();
  2655. size = end - start;
  2656. /* XXX: extra loop to check we really don't overlap preallocations */
  2657. rcu_read_lock();
  2658. list_for_each_entry_rcu(pa, &ei->i_prealloc_list, pa_inode_list) {
  2659. ext4_lblk_t pa_end;
  2660. spin_lock(&pa->pa_lock);
  2661. if (pa->pa_deleted == 0) {
  2662. pa_end = pa->pa_lstart + pa->pa_len;
  2663. BUG_ON(!(start >= pa_end || end <= pa->pa_lstart));
  2664. }
  2665. spin_unlock(&pa->pa_lock);
  2666. }
  2667. rcu_read_unlock();
  2668. if (start + size <= ac->ac_o_ex.fe_logical &&
  2669. start > ac->ac_o_ex.fe_logical) {
  2670. printk(KERN_ERR "start %lu, size %lu, fe_logical %lu\n",
  2671. (unsigned long) start, (unsigned long) size,
  2672. (unsigned long) ac->ac_o_ex.fe_logical);
  2673. }
  2674. BUG_ON(start + size <= ac->ac_o_ex.fe_logical &&
  2675. start > ac->ac_o_ex.fe_logical);
  2676. BUG_ON(size <= 0 || size > EXT4_BLOCKS_PER_GROUP(ac->ac_sb));
  2677. /* now prepare goal request */
  2678. /* XXX: is it better to align blocks WRT to logical
  2679. * placement or satisfy big request as is */
  2680. ac->ac_g_ex.fe_logical = start;
  2681. ac->ac_g_ex.fe_len = size;
  2682. /* define goal start in order to merge */
  2683. if (ar->pright && (ar->lright == (start + size))) {
  2684. /* merge to the right */
  2685. ext4_get_group_no_and_offset(ac->ac_sb, ar->pright - size,
  2686. &ac->ac_f_ex.fe_group,
  2687. &ac->ac_f_ex.fe_start);
  2688. ac->ac_flags |= EXT4_MB_HINT_TRY_GOAL;
  2689. }
  2690. if (ar->pleft && (ar->lleft + 1 == start)) {
  2691. /* merge to the left */
  2692. ext4_get_group_no_and_offset(ac->ac_sb, ar->pleft + 1,
  2693. &ac->ac_f_ex.fe_group,
  2694. &ac->ac_f_ex.fe_start);
  2695. ac->ac_flags |= EXT4_MB_HINT_TRY_GOAL;
  2696. }
  2697. mb_debug(1, "goal: %u(was %u) blocks at %u\n", (unsigned) size,
  2698. (unsigned) orig_size, (unsigned) start);
  2699. }
  2700. static void ext4_mb_collect_stats(struct ext4_allocation_context *ac)
  2701. {
  2702. struct ext4_sb_info *sbi = EXT4_SB(ac->ac_sb);
  2703. if (sbi->s_mb_stats && ac->ac_g_ex.fe_len > 1) {
  2704. atomic_inc(&sbi->s_bal_reqs);
  2705. atomic_add(ac->ac_b_ex.fe_len, &sbi->s_bal_allocated);
  2706. if (ac->ac_b_ex.fe_len >= ac->ac_o_ex.fe_len)
  2707. atomic_inc(&sbi->s_bal_success);
  2708. atomic_add(ac->ac_found, &sbi->s_bal_ex_scanned);
  2709. if (ac->ac_g_ex.fe_start == ac->ac_b_ex.fe_start &&
  2710. ac->ac_g_ex.fe_group == ac->ac_b_ex.fe_group)
  2711. atomic_inc(&sbi->s_bal_goals);
  2712. if (ac->ac_found > sbi->s_mb_max_to_scan)
  2713. atomic_inc(&sbi->s_bal_breaks);
  2714. }
  2715. if (ac->ac_op == EXT4_MB_HISTORY_ALLOC)
  2716. trace_ext4_mballoc_alloc(ac);
  2717. else
  2718. trace_ext4_mballoc_prealloc(ac);
  2719. }
  2720. /*
  2721. * Called on failure; free up any blocks from the inode PA for this
  2722. * context. We don't need this for MB_GROUP_PA because we only change
  2723. * pa_free in ext4_mb_release_context(), but on failure, we've already
  2724. * zeroed out ac->ac_b_ex.fe_len, so group_pa->pa_free is not changed.
  2725. */
  2726. static void ext4_discard_allocated_blocks(struct ext4_allocation_context *ac)
  2727. {
  2728. struct ext4_prealloc_space *pa = ac->ac_pa;
  2729. int len;
  2730. if (pa && pa->pa_type == MB_INODE_PA) {
  2731. len = ac->ac_b_ex.fe_len;
  2732. pa->pa_free += len;
  2733. }
  2734. }
  2735. /*
  2736. * use blocks preallocated to inode
  2737. */
  2738. static void ext4_mb_use_inode_pa(struct ext4_allocation_context *ac,
  2739. struct ext4_prealloc_space *pa)
  2740. {
  2741. ext4_fsblk_t start;
  2742. ext4_fsblk_t end;
  2743. int len;
  2744. /* found preallocated blocks, use them */
  2745. start = pa->pa_pstart + (ac->ac_o_ex.fe_logical - pa->pa_lstart);
  2746. end = min(pa->pa_pstart + pa->pa_len, start + ac->ac_o_ex.fe_len);
  2747. len = end - start;
  2748. ext4_get_group_no_and_offset(ac->ac_sb, start, &ac->ac_b_ex.fe_group,
  2749. &ac->ac_b_ex.fe_start);
  2750. ac->ac_b_ex.fe_len = len;
  2751. ac->ac_status = AC_STATUS_FOUND;
  2752. ac->ac_pa = pa;
  2753. BUG_ON(start < pa->pa_pstart);
  2754. BUG_ON(start + len > pa->pa_pstart + pa->pa_len);
  2755. BUG_ON(pa->pa_free < len);
  2756. pa->pa_free -= len;
  2757. mb_debug(1, "use %llu/%u from inode pa %p\n", start, len, pa);
  2758. }
  2759. /*
  2760. * use blocks preallocated to locality group
  2761. */
  2762. static void ext4_mb_use_group_pa(struct ext4_allocation_context *ac,
  2763. struct ext4_prealloc_space *pa)
  2764. {
  2765. unsigned int len = ac->ac_o_ex.fe_len;
  2766. ext4_get_group_no_and_offset(ac->ac_sb, pa->pa_pstart,
  2767. &ac->ac_b_ex.fe_group,
  2768. &ac->ac_b_ex.fe_start);
  2769. ac->ac_b_ex.fe_len = len;
  2770. ac->ac_status = AC_STATUS_FOUND;
  2771. ac->ac_pa = pa;
  2772. /* we don't correct pa_pstart or pa_plen here to avoid
  2773. * possible race when the group is being loaded concurrently
  2774. * instead we correct pa later, after blocks are marked
  2775. * in on-disk bitmap -- see ext4_mb_release_context()
  2776. * Other CPUs are prevented from allocating from this pa by lg_mutex
  2777. */
  2778. mb_debug(1, "use %u/%u from group pa %p\n", pa->pa_lstart-len, len, pa);
  2779. }
  2780. /*
  2781. * Return the prealloc space that have minimal distance
  2782. * from the goal block. @cpa is the prealloc
  2783. * space that is having currently known minimal distance
  2784. * from the goal block.
  2785. */
  2786. static struct ext4_prealloc_space *
  2787. ext4_mb_check_group_pa(ext4_fsblk_t goal_block,
  2788. struct ext4_prealloc_space *pa,
  2789. struct ext4_prealloc_space *cpa)
  2790. {
  2791. ext4_fsblk_t cur_distance, new_distance;
  2792. if (cpa == NULL) {
  2793. atomic_inc(&pa->pa_count);
  2794. return pa;
  2795. }
  2796. cur_distance = abs(goal_block - cpa->pa_pstart);
  2797. new_distance = abs(goal_block - pa->pa_pstart);
  2798. if (cur_distance <= new_distance)
  2799. return cpa;
  2800. /* drop the previous reference */
  2801. atomic_dec(&cpa->pa_count);
  2802. atomic_inc(&pa->pa_count);
  2803. return pa;
  2804. }
  2805. /*
  2806. * search goal blocks in preallocated space
  2807. */
  2808. static noinline_for_stack int
  2809. ext4_mb_use_preallocated(struct ext4_allocation_context *ac)
  2810. {
  2811. int order, i;
  2812. struct ext4_inode_info *ei = EXT4_I(ac->ac_inode);
  2813. struct ext4_locality_group *lg;
  2814. struct ext4_prealloc_space *pa, *cpa = NULL;
  2815. ext4_fsblk_t goal_block;
  2816. /* only data can be preallocated */
  2817. if (!(ac->ac_flags & EXT4_MB_HINT_DATA))
  2818. return 0;
  2819. /* first, try per-file preallocation */
  2820. rcu_read_lock();
  2821. list_for_each_entry_rcu(pa, &ei->i_prealloc_list, pa_inode_list) {
  2822. /* all fields in this condition don't change,
  2823. * so we can skip locking for them */
  2824. if (ac->ac_o_ex.fe_logical < pa->pa_lstart ||
  2825. ac->ac_o_ex.fe_logical >= pa->pa_lstart + pa->pa_len)
  2826. continue;
  2827. /* non-extent files can't have physical blocks past 2^32 */
  2828. if (!(ext4_test_inode_flag(ac->ac_inode, EXT4_INODE_EXTENTS)) &&
  2829. pa->pa_pstart + pa->pa_len > EXT4_MAX_BLOCK_FILE_PHYS)
  2830. continue;
  2831. /* found preallocated blocks, use them */
  2832. spin_lock(&pa->pa_lock);
  2833. if (pa->pa_deleted == 0 && pa->pa_free) {
  2834. atomic_inc(&pa->pa_count);
  2835. ext4_mb_use_inode_pa(ac, pa);
  2836. spin_unlock(&pa->pa_lock);
  2837. ac->ac_criteria = 10;
  2838. rcu_read_unlock();
  2839. return 1;
  2840. }
  2841. spin_unlock(&pa->pa_lock);
  2842. }
  2843. rcu_read_unlock();
  2844. /* can we use group allocation? */
  2845. if (!(ac->ac_flags & EXT4_MB_HINT_GROUP_ALLOC))
  2846. return 0;
  2847. /* inode may have no locality group for some reason */
  2848. lg = ac->ac_lg;
  2849. if (lg == NULL)
  2850. return 0;
  2851. order = fls(ac->ac_o_ex.fe_len) - 1;
  2852. if (order > PREALLOC_TB_SIZE - 1)
  2853. /* The max size of hash table is PREALLOC_TB_SIZE */
  2854. order = PREALLOC_TB_SIZE - 1;
  2855. goal_block = ext4_grp_offs_to_block(ac->ac_sb, &ac->ac_g_ex);
  2856. /*
  2857. * search for the prealloc space that is having
  2858. * minimal distance from the goal block.
  2859. */
  2860. for (i = order; i < PREALLOC_TB_SIZE; i++) {
  2861. rcu_read_lock();
  2862. list_for_each_entry_rcu(pa, &lg->lg_prealloc_list[i],
  2863. pa_inode_list) {
  2864. spin_lock(&pa->pa_lock);
  2865. if (pa->pa_deleted == 0 &&
  2866. pa->pa_free >= ac->ac_o_ex.fe_len) {
  2867. cpa = ext4_mb_check_group_pa(goal_block,
  2868. pa, cpa);
  2869. }
  2870. spin_unlock(&pa->pa_lock);
  2871. }
  2872. rcu_read_unlock();
  2873. }
  2874. if (cpa) {
  2875. ext4_mb_use_group_pa(ac, cpa);
  2876. ac->ac_criteria = 20;
  2877. return 1;
  2878. }
  2879. return 0;
  2880. }
  2881. /*
  2882. * the function goes through all block freed in the group
  2883. * but not yet committed and marks them used in in-core bitmap.
  2884. * buddy must be generated from this bitmap
  2885. * Need to be called with the ext4 group lock held
  2886. */
  2887. static void ext4_mb_generate_from_freelist(struct super_block *sb, void *bitmap,
  2888. ext4_group_t group)
  2889. {
  2890. struct rb_node *n;
  2891. struct ext4_group_info *grp;
  2892. struct ext4_free_data *entry;
  2893. grp = ext4_get_group_info(sb, group);
  2894. n = rb_first(&(grp->bb_free_root));
  2895. while (n) {
  2896. entry = rb_entry(n, struct ext4_free_data, node);
  2897. mb_set_bits(bitmap, entry->start_blk, entry->count);
  2898. n = rb_next(n);
  2899. }
  2900. return;
  2901. }
  2902. /*
  2903. * the function goes through all preallocation in this group and marks them
  2904. * used in in-core bitmap. buddy must be generated from this bitmap
  2905. * Need to be called with ext4 group lock held
  2906. */
  2907. static noinline_for_stack
  2908. void ext4_mb_generate_from_pa(struct super_block *sb, void *bitmap,
  2909. ext4_group_t group)
  2910. {
  2911. struct ext4_group_info *grp = ext4_get_group_info(sb, group);
  2912. struct ext4_prealloc_space *pa;
  2913. struct list_head *cur;
  2914. ext4_group_t groupnr;
  2915. ext4_grpblk_t start;
  2916. int preallocated = 0;
  2917. int count = 0;
  2918. int len;
  2919. /* all form of preallocation discards first load group,
  2920. * so the only competing code is preallocation use.
  2921. * we don't need any locking here
  2922. * notice we do NOT ignore preallocations with pa_deleted
  2923. * otherwise we could leave used blocks available for
  2924. * allocation in buddy when concurrent ext4_mb_put_pa()
  2925. * is dropping preallocation
  2926. */
  2927. list_for_each(cur, &grp->bb_prealloc_list) {
  2928. pa = list_entry(cur, struct ext4_prealloc_space, pa_group_list);
  2929. spin_lock(&pa->pa_lock);
  2930. ext4_get_group_no_and_offset(sb, pa->pa_pstart,
  2931. &groupnr, &start);
  2932. len = pa->pa_len;
  2933. spin_unlock(&pa->pa_lock);
  2934. if (unlikely(len == 0))
  2935. continue;
  2936. BUG_ON(groupnr != group);
  2937. mb_set_bits(bitmap, start, len);
  2938. preallocated += len;
  2939. count++;
  2940. }
  2941. mb_debug(1, "prellocated %u for group %u\n", preallocated, group);
  2942. }
  2943. static void ext4_mb_pa_callback(struct rcu_head *head)
  2944. {
  2945. struct ext4_prealloc_space *pa;
  2946. pa = container_of(head, struct ext4_prealloc_space, u.pa_rcu);
  2947. kmem_cache_free(ext4_pspace_cachep, pa);
  2948. }
  2949. /*
  2950. * drops a reference to preallocated space descriptor
  2951. * if this was the last reference and the space is consumed
  2952. */
  2953. static void ext4_mb_put_pa(struct ext4_allocation_context *ac,
  2954. struct super_block *sb, struct ext4_prealloc_space *pa)
  2955. {
  2956. ext4_group_t grp;
  2957. ext4_fsblk_t grp_blk;
  2958. if (!atomic_dec_and_test(&pa->pa_count) || pa->pa_free != 0)
  2959. return;
  2960. /* in this short window concurrent discard can set pa_deleted */
  2961. spin_lock(&pa->pa_lock);
  2962. if (pa->pa_deleted == 1) {
  2963. spin_unlock(&pa->pa_lock);
  2964. return;
  2965. }
  2966. pa->pa_deleted = 1;
  2967. spin_unlock(&pa->pa_lock);
  2968. grp_blk = pa->pa_pstart;
  2969. /*
  2970. * If doing group-based preallocation, pa_pstart may be in the
  2971. * next group when pa is used up
  2972. */
  2973. if (pa->pa_type == MB_GROUP_PA)
  2974. grp_blk--;
  2975. ext4_get_group_no_and_offset(sb, grp_blk, &grp, NULL);
  2976. /*
  2977. * possible race:
  2978. *
  2979. * P1 (buddy init) P2 (regular allocation)
  2980. * find block B in PA
  2981. * copy on-disk bitmap to buddy
  2982. * mark B in on-disk bitmap
  2983. * drop PA from group
  2984. * mark all PAs in buddy
  2985. *
  2986. * thus, P1 initializes buddy with B available. to prevent this
  2987. * we make "copy" and "mark all PAs" atomic and serialize "drop PA"
  2988. * against that pair
  2989. */
  2990. ext4_lock_group(sb, grp);
  2991. list_del(&pa->pa_group_list);
  2992. ext4_unlock_group(sb, grp);
  2993. spin_lock(pa->pa_obj_lock);
  2994. list_del_rcu(&pa->pa_inode_list);
  2995. spin_unlock(pa->pa_obj_lock);
  2996. call_rcu(&(pa)->u.pa_rcu, ext4_mb_pa_callback);
  2997. }
  2998. /*
  2999. * creates new preallocated space for given inode
  3000. */
  3001. static noinline_for_stack int
  3002. ext4_mb_new_inode_pa(struct ext4_allocation_context *ac)
  3003. {
  3004. struct super_block *sb = ac->ac_sb;
  3005. struct ext4_prealloc_space *pa;
  3006. struct ext4_group_info *grp;
  3007. struct ext4_inode_info *ei;
  3008. /* preallocate only when found space is larger then requested */
  3009. BUG_ON(ac->ac_o_ex.fe_len >= ac->ac_b_ex.fe_len);
  3010. BUG_ON(ac->ac_status != AC_STATUS_FOUND);
  3011. BUG_ON(!S_ISREG(ac->ac_inode->i_mode));
  3012. pa = kmem_cache_alloc(ext4_pspace_cachep, GFP_NOFS);
  3013. if (pa == NULL)
  3014. return -ENOMEM;
  3015. if (ac->ac_b_ex.fe_len < ac->ac_g_ex.fe_len) {
  3016. int winl;
  3017. int wins;
  3018. int win;
  3019. int offs;
  3020. /* we can't allocate as much as normalizer wants.
  3021. * so, found space must get proper lstart
  3022. * to cover original request */
  3023. BUG_ON(ac->ac_g_ex.fe_logical > ac->ac_o_ex.fe_logical);
  3024. BUG_ON(ac->ac_g_ex.fe_len < ac->ac_o_ex.fe_len);
  3025. /* we're limited by original request in that
  3026. * logical block must be covered any way
  3027. * winl is window we can move our chunk within */
  3028. winl = ac->ac_o_ex.fe_logical - ac->ac_g_ex.fe_logical;
  3029. /* also, we should cover whole original request */
  3030. wins = ac->ac_b_ex.fe_len - ac->ac_o_ex.fe_len;
  3031. /* the smallest one defines real window */
  3032. win = min(winl, wins);
  3033. offs = ac->ac_o_ex.fe_logical % ac->ac_b_ex.fe_len;
  3034. if (offs && offs < win)
  3035. win = offs;
  3036. ac->ac_b_ex.fe_logical = ac->ac_o_ex.fe_logical - win;
  3037. BUG_ON(ac->ac_o_ex.fe_logical < ac->ac_b_ex.fe_logical);
  3038. BUG_ON(ac->ac_o_ex.fe_len > ac->ac_b_ex.fe_len);
  3039. }
  3040. /* preallocation can change ac_b_ex, thus we store actually
  3041. * allocated blocks for history */
  3042. ac->ac_f_ex = ac->ac_b_ex;
  3043. pa->pa_lstart = ac->ac_b_ex.fe_logical;
  3044. pa->pa_pstart = ext4_grp_offs_to_block(sb, &ac->ac_b_ex);
  3045. pa->pa_len = ac->ac_b_ex.fe_len;
  3046. pa->pa_free = pa->pa_len;
  3047. atomic_set(&pa->pa_count, 1);
  3048. spin_lock_init(&pa->pa_lock);
  3049. INIT_LIST_HEAD(&pa->pa_inode_list);
  3050. INIT_LIST_HEAD(&pa->pa_group_list);
  3051. pa->pa_deleted = 0;
  3052. pa->pa_type = MB_INODE_PA;
  3053. mb_debug(1, "new inode pa %p: %llu/%u for %u\n", pa,
  3054. pa->pa_pstart, pa->pa_len, pa->pa_lstart);
  3055. trace_ext4_mb_new_inode_pa(ac, pa);
  3056. ext4_mb_use_inode_pa(ac, pa);
  3057. atomic_add(pa->pa_free, &EXT4_SB(sb)->s_mb_preallocated);
  3058. ei = EXT4_I(ac->ac_inode);
  3059. grp = ext4_get_group_info(sb, ac->ac_b_ex.fe_group);
  3060. pa->pa_obj_lock = &ei->i_prealloc_lock;
  3061. pa->pa_inode = ac->ac_inode;
  3062. ext4_lock_group(sb, ac->ac_b_ex.fe_group);
  3063. list_add(&pa->pa_group_list, &grp->bb_prealloc_list);
  3064. ext4_unlock_group(sb, ac->ac_b_ex.fe_group);
  3065. spin_lock(pa->pa_obj_lock);
  3066. list_add_rcu(&pa->pa_inode_list, &ei->i_prealloc_list);
  3067. spin_unlock(pa->pa_obj_lock);
  3068. return 0;
  3069. }
  3070. /*
  3071. * creates new preallocated space for locality group inodes belongs to
  3072. */
  3073. static noinline_for_stack int
  3074. ext4_mb_new_group_pa(struct ext4_allocation_context *ac)
  3075. {
  3076. struct super_block *sb = ac->ac_sb;
  3077. struct ext4_locality_group *lg;
  3078. struct ext4_prealloc_space *pa;
  3079. struct ext4_group_info *grp;
  3080. /* preallocate only when found space is larger then requested */
  3081. BUG_ON(ac->ac_o_ex.fe_len >= ac->ac_b_ex.fe_len);
  3082. BUG_ON(ac->ac_status != AC_STATUS_FOUND);
  3083. BUG_ON(!S_ISREG(ac->ac_inode->i_mode));
  3084. BUG_ON(ext4_pspace_cachep == NULL);
  3085. pa = kmem_cache_alloc(ext4_pspace_cachep, GFP_NOFS);
  3086. if (pa == NULL)
  3087. return -ENOMEM;
  3088. /* preallocation can change ac_b_ex, thus we store actually
  3089. * allocated blocks for history */
  3090. ac->ac_f_ex = ac->ac_b_ex;
  3091. pa->pa_pstart = ext4_grp_offs_to_block(sb, &ac->ac_b_ex);
  3092. pa->pa_lstart = pa->pa_pstart;
  3093. pa->pa_len = ac->ac_b_ex.fe_len;
  3094. pa->pa_free = pa->pa_len;
  3095. atomic_set(&pa->pa_count, 1);
  3096. spin_lock_init(&pa->pa_lock);
  3097. INIT_LIST_HEAD(&pa->pa_inode_list);
  3098. INIT_LIST_HEAD(&pa->pa_group_list);
  3099. pa->pa_deleted = 0;
  3100. pa->pa_type = MB_GROUP_PA;
  3101. mb_debug(1, "new group pa %p: %llu/%u for %u\n", pa,
  3102. pa->pa_pstart, pa->pa_len, pa->pa_lstart);
  3103. trace_ext4_mb_new_group_pa(ac, pa);
  3104. ext4_mb_use_group_pa(ac, pa);
  3105. atomic_add(pa->pa_free, &EXT4_SB(sb)->s_mb_preallocated);
  3106. grp = ext4_get_group_info(sb, ac->ac_b_ex.fe_group);
  3107. lg = ac->ac_lg;
  3108. BUG_ON(lg == NULL);
  3109. pa->pa_obj_lock = &lg->lg_prealloc_lock;
  3110. pa->pa_inode = NULL;
  3111. ext4_lock_group(sb, ac->ac_b_ex.fe_group);
  3112. list_add(&pa->pa_group_list, &grp->bb_prealloc_list);
  3113. ext4_unlock_group(sb, ac->ac_b_ex.fe_group);
  3114. /*
  3115. * We will later add the new pa to the right bucket
  3116. * after updating the pa_free in ext4_mb_release_context
  3117. */
  3118. return 0;
  3119. }
  3120. static int ext4_mb_new_preallocation(struct ext4_allocation_context *ac)
  3121. {
  3122. int err;
  3123. if (ac->ac_flags & EXT4_MB_HINT_GROUP_ALLOC)
  3124. err = ext4_mb_new_group_pa(ac);
  3125. else
  3126. err = ext4_mb_new_inode_pa(ac);
  3127. return err;
  3128. }
  3129. /*
  3130. * finds all unused blocks in on-disk bitmap, frees them in
  3131. * in-core bitmap and buddy.
  3132. * @pa must be unlinked from inode and group lists, so that
  3133. * nobody else can find/use it.
  3134. * the caller MUST hold group/inode locks.
  3135. * TODO: optimize the case when there are no in-core structures yet
  3136. */
  3137. static noinline_for_stack int
  3138. ext4_mb_release_inode_pa(struct ext4_buddy *e4b, struct buffer_head *bitmap_bh,
  3139. struct ext4_prealloc_space *pa)
  3140. {
  3141. struct super_block *sb = e4b->bd_sb;
  3142. struct ext4_sb_info *sbi = EXT4_SB(sb);
  3143. unsigned int end;
  3144. unsigned int next;
  3145. ext4_group_t group;
  3146. ext4_grpblk_t bit;
  3147. unsigned long long grp_blk_start;
  3148. int err = 0;
  3149. int free = 0;
  3150. BUG_ON(pa->pa_deleted == 0);
  3151. ext4_get_group_no_and_offset(sb, pa->pa_pstart, &group, &bit);
  3152. grp_blk_start = pa->pa_pstart - bit;
  3153. BUG_ON(group != e4b->bd_group && pa->pa_len != 0);
  3154. end = bit + pa->pa_len;
  3155. while (bit < end) {
  3156. bit = mb_find_next_zero_bit(bitmap_bh->b_data, end, bit);
  3157. if (bit >= end)
  3158. break;
  3159. next = mb_find_next_bit(bitmap_bh->b_data, end, bit);
  3160. mb_debug(1, " free preallocated %u/%u in group %u\n",
  3161. (unsigned) ext4_group_first_block_no(sb, group) + bit,
  3162. (unsigned) next - bit, (unsigned) group);
  3163. free += next - bit;
  3164. trace_ext4_mballoc_discard(sb, NULL, group, bit, next - bit);
  3165. trace_ext4_mb_release_inode_pa(sb, pa->pa_inode, pa,
  3166. grp_blk_start + bit, next - bit);
  3167. mb_free_blocks(pa->pa_inode, e4b, bit, next - bit);
  3168. bit = next + 1;
  3169. }
  3170. if (free != pa->pa_free) {
  3171. printk(KERN_CRIT "pa %p: logic %lu, phys. %lu, len %lu\n",
  3172. pa, (unsigned long) pa->pa_lstart,
  3173. (unsigned long) pa->pa_pstart,
  3174. (unsigned long) pa->pa_len);
  3175. ext4_grp_locked_error(sb, group, 0, 0, "free %u, pa_free %u",
  3176. free, pa->pa_free);
  3177. /*
  3178. * pa is already deleted so we use the value obtained
  3179. * from the bitmap and continue.
  3180. */
  3181. }
  3182. atomic_add(free, &sbi->s_mb_discarded);
  3183. return err;
  3184. }
  3185. static noinline_for_stack int
  3186. ext4_mb_release_group_pa(struct ext4_buddy *e4b,
  3187. struct ext4_prealloc_space *pa)
  3188. {
  3189. struct super_block *sb = e4b->bd_sb;
  3190. ext4_group_t group;
  3191. ext4_grpblk_t bit;
  3192. trace_ext4_mb_release_group_pa(sb, pa);
  3193. BUG_ON(pa->pa_deleted == 0);
  3194. ext4_get_group_no_and_offset(sb, pa->pa_pstart, &group, &bit);
  3195. BUG_ON(group != e4b->bd_group && pa->pa_len != 0);
  3196. mb_free_blocks(pa->pa_inode, e4b, bit, pa->pa_len);
  3197. atomic_add(pa->pa_len, &EXT4_SB(sb)->s_mb_discarded);
  3198. trace_ext4_mballoc_discard(sb, NULL, group, bit, pa->pa_len);
  3199. return 0;
  3200. }
  3201. /*
  3202. * releases all preallocations in given group
  3203. *
  3204. * first, we need to decide discard policy:
  3205. * - when do we discard
  3206. * 1) ENOSPC
  3207. * - how many do we discard
  3208. * 1) how many requested
  3209. */
  3210. static noinline_for_stack int
  3211. ext4_mb_discard_group_preallocations(struct super_block *sb,
  3212. ext4_group_t group, int needed)
  3213. {
  3214. struct ext4_group_info *grp = ext4_get_group_info(sb, group);
  3215. struct buffer_head *bitmap_bh = NULL;
  3216. struct ext4_prealloc_space *pa, *tmp;
  3217. struct list_head list;
  3218. struct ext4_buddy e4b;
  3219. int err;
  3220. int busy = 0;
  3221. int free = 0;
  3222. mb_debug(1, "discard preallocation for group %u\n", group);
  3223. if (list_empty(&grp->bb_prealloc_list))
  3224. return 0;
  3225. bitmap_bh = ext4_read_block_bitmap(sb, group);
  3226. if (bitmap_bh == NULL) {
  3227. ext4_error(sb, "Error reading block bitmap for %u", group);
  3228. return 0;
  3229. }
  3230. err = ext4_mb_load_buddy(sb, group, &e4b);
  3231. if (err) {
  3232. ext4_error(sb, "Error loading buddy information for %u", group);
  3233. put_bh(bitmap_bh);
  3234. return 0;
  3235. }
  3236. if (needed == 0)
  3237. needed = EXT4_BLOCKS_PER_GROUP(sb) + 1;
  3238. INIT_LIST_HEAD(&list);
  3239. repeat:
  3240. ext4_lock_group(sb, group);
  3241. list_for_each_entry_safe(pa, tmp,
  3242. &grp->bb_prealloc_list, pa_group_list) {
  3243. spin_lock(&pa->pa_lock);
  3244. if (atomic_read(&pa->pa_count)) {
  3245. spin_unlock(&pa->pa_lock);
  3246. busy = 1;
  3247. continue;
  3248. }
  3249. if (pa->pa_deleted) {
  3250. spin_unlock(&pa->pa_lock);
  3251. continue;
  3252. }
  3253. /* seems this one can be freed ... */
  3254. pa->pa_deleted = 1;
  3255. /* we can trust pa_free ... */
  3256. free += pa->pa_free;
  3257. spin_unlock(&pa->pa_lock);
  3258. list_del(&pa->pa_group_list);
  3259. list_add(&pa->u.pa_tmp_list, &list);
  3260. }
  3261. /* if we still need more blocks and some PAs were used, try again */
  3262. if (free < needed && busy) {
  3263. busy = 0;
  3264. ext4_unlock_group(sb, group);
  3265. /*
  3266. * Yield the CPU here so that we don't get soft lockup
  3267. * in non preempt case.
  3268. */
  3269. yield();
  3270. goto repeat;
  3271. }
  3272. /* found anything to free? */
  3273. if (list_empty(&list)) {
  3274. BUG_ON(free != 0);
  3275. goto out;
  3276. }
  3277. /* now free all selected PAs */
  3278. list_for_each_entry_safe(pa, tmp, &list, u.pa_tmp_list) {
  3279. /* remove from object (inode or locality group) */
  3280. spin_lock(pa->pa_obj_lock);
  3281. list_del_rcu(&pa->pa_inode_list);
  3282. spin_unlock(pa->pa_obj_lock);
  3283. if (pa->pa_type == MB_GROUP_PA)
  3284. ext4_mb_release_group_pa(&e4b, pa);
  3285. else
  3286. ext4_mb_release_inode_pa(&e4b, bitmap_bh, pa);
  3287. list_del(&pa->u.pa_tmp_list);
  3288. call_rcu(&(pa)->u.pa_rcu, ext4_mb_pa_callback);
  3289. }
  3290. out:
  3291. ext4_unlock_group(sb, group);
  3292. ext4_mb_unload_buddy(&e4b);
  3293. put_bh(bitmap_bh);
  3294. return free;
  3295. }
  3296. /*
  3297. * releases all non-used preallocated blocks for given inode
  3298. *
  3299. * It's important to discard preallocations under i_data_sem
  3300. * We don't want another block to be served from the prealloc
  3301. * space when we are discarding the inode prealloc space.
  3302. *
  3303. * FIXME!! Make sure it is valid at all the call sites
  3304. */
  3305. void ext4_discard_preallocations(struct inode *inode)
  3306. {
  3307. struct ext4_inode_info *ei = EXT4_I(inode);
  3308. struct super_block *sb = inode->i_sb;
  3309. struct buffer_head *bitmap_bh = NULL;
  3310. struct ext4_prealloc_space *pa, *tmp;
  3311. ext4_group_t group = 0;
  3312. struct list_head list;
  3313. struct ext4_buddy e4b;
  3314. int err;
  3315. if (!S_ISREG(inode->i_mode)) {
  3316. /*BUG_ON(!list_empty(&ei->i_prealloc_list));*/
  3317. return;
  3318. }
  3319. mb_debug(1, "discard preallocation for inode %lu\n", inode->i_ino);
  3320. trace_ext4_discard_preallocations(inode);
  3321. INIT_LIST_HEAD(&list);
  3322. repeat:
  3323. /* first, collect all pa's in the inode */
  3324. spin_lock(&ei->i_prealloc_lock);
  3325. while (!list_empty(&ei->i_prealloc_list)) {
  3326. pa = list_entry(ei->i_prealloc_list.next,
  3327. struct ext4_prealloc_space, pa_inode_list);
  3328. BUG_ON(pa->pa_obj_lock != &ei->i_prealloc_lock);
  3329. spin_lock(&pa->pa_lock);
  3330. if (atomic_read(&pa->pa_count)) {
  3331. /* this shouldn't happen often - nobody should
  3332. * use preallocation while we're discarding it */
  3333. spin_unlock(&pa->pa_lock);
  3334. spin_unlock(&ei->i_prealloc_lock);
  3335. printk(KERN_ERR "uh-oh! used pa while discarding\n");
  3336. WARN_ON(1);
  3337. schedule_timeout_uninterruptible(HZ);
  3338. goto repeat;
  3339. }
  3340. if (pa->pa_deleted == 0) {
  3341. pa->pa_deleted = 1;
  3342. spin_unlock(&pa->pa_lock);
  3343. list_del_rcu(&pa->pa_inode_list);
  3344. list_add(&pa->u.pa_tmp_list, &list);
  3345. continue;
  3346. }
  3347. /* someone is deleting pa right now */
  3348. spin_unlock(&pa->pa_lock);
  3349. spin_unlock(&ei->i_prealloc_lock);
  3350. /* we have to wait here because pa_deleted
  3351. * doesn't mean pa is already unlinked from
  3352. * the list. as we might be called from
  3353. * ->clear_inode() the inode will get freed
  3354. * and concurrent thread which is unlinking
  3355. * pa from inode's list may access already
  3356. * freed memory, bad-bad-bad */
  3357. /* XXX: if this happens too often, we can
  3358. * add a flag to force wait only in case
  3359. * of ->clear_inode(), but not in case of
  3360. * regular truncate */
  3361. schedule_timeout_uninterruptible(HZ);
  3362. goto repeat;
  3363. }
  3364. spin_unlock(&ei->i_prealloc_lock);
  3365. list_for_each_entry_safe(pa, tmp, &list, u.pa_tmp_list) {
  3366. BUG_ON(pa->pa_type != MB_INODE_PA);
  3367. ext4_get_group_no_and_offset(sb, pa->pa_pstart, &group, NULL);
  3368. err = ext4_mb_load_buddy(sb, group, &e4b);
  3369. if (err) {
  3370. ext4_error(sb, "Error loading buddy information for %u",
  3371. group);
  3372. continue;
  3373. }
  3374. bitmap_bh = ext4_read_block_bitmap(sb, group);
  3375. if (bitmap_bh == NULL) {
  3376. ext4_error(sb, "Error reading block bitmap for %u",
  3377. group);
  3378. ext4_mb_unload_buddy(&e4b);
  3379. continue;
  3380. }
  3381. ext4_lock_group(sb, group);
  3382. list_del(&pa->pa_group_list);
  3383. ext4_mb_release_inode_pa(&e4b, bitmap_bh, pa);
  3384. ext4_unlock_group(sb, group);
  3385. ext4_mb_unload_buddy(&e4b);
  3386. put_bh(bitmap_bh);
  3387. list_del(&pa->u.pa_tmp_list);
  3388. call_rcu(&(pa)->u.pa_rcu, ext4_mb_pa_callback);
  3389. }
  3390. }
  3391. #ifdef CONFIG_EXT4_DEBUG
  3392. static void ext4_mb_show_ac(struct ext4_allocation_context *ac)
  3393. {
  3394. struct super_block *sb = ac->ac_sb;
  3395. ext4_group_t ngroups, i;
  3396. if (!mb_enable_debug ||
  3397. (EXT4_SB(sb)->s_mount_flags & EXT4_MF_FS_ABORTED))
  3398. return;
  3399. printk(KERN_ERR "EXT4-fs: Can't allocate:"
  3400. " Allocation context details:\n");
  3401. printk(KERN_ERR "EXT4-fs: status %d flags %d\n",
  3402. ac->ac_status, ac->ac_flags);
  3403. printk(KERN_ERR "EXT4-fs: orig %lu/%lu/%lu@%lu, goal %lu/%lu/%lu@%lu, "
  3404. "best %lu/%lu/%lu@%lu cr %d\n",
  3405. (unsigned long)ac->ac_o_ex.fe_group,
  3406. (unsigned long)ac->ac_o_ex.fe_start,
  3407. (unsigned long)ac->ac_o_ex.fe_len,
  3408. (unsigned long)ac->ac_o_ex.fe_logical,
  3409. (unsigned long)ac->ac_g_ex.fe_group,
  3410. (unsigned long)ac->ac_g_ex.fe_start,
  3411. (unsigned long)ac->ac_g_ex.fe_len,
  3412. (unsigned long)ac->ac_g_ex.fe_logical,
  3413. (unsigned long)ac->ac_b_ex.fe_group,
  3414. (unsigned long)ac->ac_b_ex.fe_start,
  3415. (unsigned long)ac->ac_b_ex.fe_len,
  3416. (unsigned long)ac->ac_b_ex.fe_logical,
  3417. (int)ac->ac_criteria);
  3418. printk(KERN_ERR "EXT4-fs: %lu scanned, %d found\n", ac->ac_ex_scanned,
  3419. ac->ac_found);
  3420. printk(KERN_ERR "EXT4-fs: groups: \n");
  3421. ngroups = ext4_get_groups_count(sb);
  3422. for (i = 0; i < ngroups; i++) {
  3423. struct ext4_group_info *grp = ext4_get_group_info(sb, i);
  3424. struct ext4_prealloc_space *pa;
  3425. ext4_grpblk_t start;
  3426. struct list_head *cur;
  3427. ext4_lock_group(sb, i);
  3428. list_for_each(cur, &grp->bb_prealloc_list) {
  3429. pa = list_entry(cur, struct ext4_prealloc_space,
  3430. pa_group_list);
  3431. spin_lock(&pa->pa_lock);
  3432. ext4_get_group_no_and_offset(sb, pa->pa_pstart,
  3433. NULL, &start);
  3434. spin_unlock(&pa->pa_lock);
  3435. printk(KERN_ERR "PA:%u:%d:%u \n", i,
  3436. start, pa->pa_len);
  3437. }
  3438. ext4_unlock_group(sb, i);
  3439. if (grp->bb_free == 0)
  3440. continue;
  3441. printk(KERN_ERR "%u: %d/%d \n",
  3442. i, grp->bb_free, grp->bb_fragments);
  3443. }
  3444. printk(KERN_ERR "\n");
  3445. }
  3446. #else
  3447. static inline void ext4_mb_show_ac(struct ext4_allocation_context *ac)
  3448. {
  3449. return;
  3450. }
  3451. #endif
  3452. /*
  3453. * We use locality group preallocation for small size file. The size of the
  3454. * file is determined by the current size or the resulting size after
  3455. * allocation which ever is larger
  3456. *
  3457. * One can tune this size via /sys/fs/ext4/<partition>/mb_stream_req
  3458. */
  3459. static void ext4_mb_group_or_file(struct ext4_allocation_context *ac)
  3460. {
  3461. struct ext4_sb_info *sbi = EXT4_SB(ac->ac_sb);
  3462. int bsbits = ac->ac_sb->s_blocksize_bits;
  3463. loff_t size, isize;
  3464. if (!(ac->ac_flags & EXT4_MB_HINT_DATA))
  3465. return;
  3466. if (unlikely(ac->ac_flags & EXT4_MB_HINT_GOAL_ONLY))
  3467. return;
  3468. size = ac->ac_o_ex.fe_logical + ac->ac_o_ex.fe_len;
  3469. isize = (i_size_read(ac->ac_inode) + ac->ac_sb->s_blocksize - 1)
  3470. >> bsbits;
  3471. if ((size == isize) &&
  3472. !ext4_fs_is_busy(sbi) &&
  3473. (atomic_read(&ac->ac_inode->i_writecount) == 0)) {
  3474. ac->ac_flags |= EXT4_MB_HINT_NOPREALLOC;
  3475. return;
  3476. }
  3477. /* don't use group allocation for large files */
  3478. size = max(size, isize);
  3479. if (size > sbi->s_mb_stream_request) {
  3480. ac->ac_flags |= EXT4_MB_STREAM_ALLOC;
  3481. return;
  3482. }
  3483. BUG_ON(ac->ac_lg != NULL);
  3484. /*
  3485. * locality group prealloc space are per cpu. The reason for having
  3486. * per cpu locality group is to reduce the contention between block
  3487. * request from multiple CPUs.
  3488. */
  3489. ac->ac_lg = __this_cpu_ptr(sbi->s_locality_groups);
  3490. /* we're going to use group allocation */
  3491. ac->ac_flags |= EXT4_MB_HINT_GROUP_ALLOC;
  3492. /* serialize all allocations in the group */
  3493. mutex_lock(&ac->ac_lg->lg_mutex);
  3494. }
  3495. static noinline_for_stack int
  3496. ext4_mb_initialize_context(struct ext4_allocation_context *ac,
  3497. struct ext4_allocation_request *ar)
  3498. {
  3499. struct super_block *sb = ar->inode->i_sb;
  3500. struct ext4_sb_info *sbi = EXT4_SB(sb);
  3501. struct ext4_super_block *es = sbi->s_es;
  3502. ext4_group_t group;
  3503. unsigned int len;
  3504. ext4_fsblk_t goal;
  3505. ext4_grpblk_t block;
  3506. /* we can't allocate > group size */
  3507. len = ar->len;
  3508. /* just a dirty hack to filter too big requests */
  3509. if (len >= EXT4_BLOCKS_PER_GROUP(sb) - 10)
  3510. len = EXT4_BLOCKS_PER_GROUP(sb) - 10;
  3511. /* start searching from the goal */
  3512. goal = ar->goal;
  3513. if (goal < le32_to_cpu(es->s_first_data_block) ||
  3514. goal >= ext4_blocks_count(es))
  3515. goal = le32_to_cpu(es->s_first_data_block);
  3516. ext4_get_group_no_and_offset(sb, goal, &group, &block);
  3517. /* set up allocation goals */
  3518. memset(ac, 0, sizeof(struct ext4_allocation_context));
  3519. ac->ac_b_ex.fe_logical = ar->logical;
  3520. ac->ac_status = AC_STATUS_CONTINUE;
  3521. ac->ac_sb = sb;
  3522. ac->ac_inode = ar->inode;
  3523. ac->ac_o_ex.fe_logical = ar->logical;
  3524. ac->ac_o_ex.fe_group = group;
  3525. ac->ac_o_ex.fe_start = block;
  3526. ac->ac_o_ex.fe_len = len;
  3527. ac->ac_g_ex.fe_logical = ar->logical;
  3528. ac->ac_g_ex.fe_group = group;
  3529. ac->ac_g_ex.fe_start = block;
  3530. ac->ac_g_ex.fe_len = len;
  3531. ac->ac_flags = ar->flags;
  3532. /* we have to define context: we'll we work with a file or
  3533. * locality group. this is a policy, actually */
  3534. ext4_mb_group_or_file(ac);
  3535. mb_debug(1, "init ac: %u blocks @ %u, goal %u, flags %x, 2^%d, "
  3536. "left: %u/%u, right %u/%u to %swritable\n",
  3537. (unsigned) ar->len, (unsigned) ar->logical,
  3538. (unsigned) ar->goal, ac->ac_flags, ac->ac_2order,
  3539. (unsigned) ar->lleft, (unsigned) ar->pleft,
  3540. (unsigned) ar->lright, (unsigned) ar->pright,
  3541. atomic_read(&ar->inode->i_writecount) ? "" : "non-");
  3542. return 0;
  3543. }
  3544. static noinline_for_stack void
  3545. ext4_mb_discard_lg_preallocations(struct super_block *sb,
  3546. struct ext4_locality_group *lg,
  3547. int order, int total_entries)
  3548. {
  3549. ext4_group_t group = 0;
  3550. struct ext4_buddy e4b;
  3551. struct list_head discard_list;
  3552. struct ext4_prealloc_space *pa, *tmp;
  3553. mb_debug(1, "discard locality group preallocation\n");
  3554. INIT_LIST_HEAD(&discard_list);
  3555. spin_lock(&lg->lg_prealloc_lock);
  3556. list_for_each_entry_rcu(pa, &lg->lg_prealloc_list[order],
  3557. pa_inode_list) {
  3558. spin_lock(&pa->pa_lock);
  3559. if (atomic_read(&pa->pa_count)) {
  3560. /*
  3561. * This is the pa that we just used
  3562. * for block allocation. So don't
  3563. * free that
  3564. */
  3565. spin_unlock(&pa->pa_lock);
  3566. continue;
  3567. }
  3568. if (pa->pa_deleted) {
  3569. spin_unlock(&pa->pa_lock);
  3570. continue;
  3571. }
  3572. /* only lg prealloc space */
  3573. BUG_ON(pa->pa_type != MB_GROUP_PA);
  3574. /* seems this one can be freed ... */
  3575. pa->pa_deleted = 1;
  3576. spin_unlock(&pa->pa_lock);
  3577. list_del_rcu(&pa->pa_inode_list);
  3578. list_add(&pa->u.pa_tmp_list, &discard_list);
  3579. total_entries--;
  3580. if (total_entries <= 5) {
  3581. /*
  3582. * we want to keep only 5 entries
  3583. * allowing it to grow to 8. This
  3584. * mak sure we don't call discard
  3585. * soon for this list.
  3586. */
  3587. break;
  3588. }
  3589. }
  3590. spin_unlock(&lg->lg_prealloc_lock);
  3591. list_for_each_entry_safe(pa, tmp, &discard_list, u.pa_tmp_list) {
  3592. ext4_get_group_no_and_offset(sb, pa->pa_pstart, &group, NULL);
  3593. if (ext4_mb_load_buddy(sb, group, &e4b)) {
  3594. ext4_error(sb, "Error loading buddy information for %u",
  3595. group);
  3596. continue;
  3597. }
  3598. ext4_lock_group(sb, group);
  3599. list_del(&pa->pa_group_list);
  3600. ext4_mb_release_group_pa(&e4b, pa);
  3601. ext4_unlock_group(sb, group);
  3602. ext4_mb_unload_buddy(&e4b);
  3603. list_del(&pa->u.pa_tmp_list);
  3604. call_rcu(&(pa)->u.pa_rcu, ext4_mb_pa_callback);
  3605. }
  3606. }
  3607. /*
  3608. * We have incremented pa_count. So it cannot be freed at this
  3609. * point. Also we hold lg_mutex. So no parallel allocation is
  3610. * possible from this lg. That means pa_free cannot be updated.
  3611. *
  3612. * A parallel ext4_mb_discard_group_preallocations is possible.
  3613. * which can cause the lg_prealloc_list to be updated.
  3614. */
  3615. static void ext4_mb_add_n_trim(struct ext4_allocation_context *ac)
  3616. {
  3617. int order, added = 0, lg_prealloc_count = 1;
  3618. struct super_block *sb = ac->ac_sb;
  3619. struct ext4_locality_group *lg = ac->ac_lg;
  3620. struct ext4_prealloc_space *tmp_pa, *pa = ac->ac_pa;
  3621. order = fls(pa->pa_free) - 1;
  3622. if (order > PREALLOC_TB_SIZE - 1)
  3623. /* The max size of hash table is PREALLOC_TB_SIZE */
  3624. order = PREALLOC_TB_SIZE - 1;
  3625. /* Add the prealloc space to lg */
  3626. rcu_read_lock();
  3627. list_for_each_entry_rcu(tmp_pa, &lg->lg_prealloc_list[order],
  3628. pa_inode_list) {
  3629. spin_lock(&tmp_pa->pa_lock);
  3630. if (tmp_pa->pa_deleted) {
  3631. spin_unlock(&tmp_pa->pa_lock);
  3632. continue;
  3633. }
  3634. if (!added && pa->pa_free < tmp_pa->pa_free) {
  3635. /* Add to the tail of the previous entry */
  3636. list_add_tail_rcu(&pa->pa_inode_list,
  3637. &tmp_pa->pa_inode_list);
  3638. added = 1;
  3639. /*
  3640. * we want to count the total
  3641. * number of entries in the list
  3642. */
  3643. }
  3644. spin_unlock(&tmp_pa->pa_lock);
  3645. lg_prealloc_count++;
  3646. }
  3647. if (!added)
  3648. list_add_tail_rcu(&pa->pa_inode_list,
  3649. &lg->lg_prealloc_list[order]);
  3650. rcu_read_unlock();
  3651. /* Now trim the list to be not more than 8 elements */
  3652. if (lg_prealloc_count > 8) {
  3653. ext4_mb_discard_lg_preallocations(sb, lg,
  3654. order, lg_prealloc_count);
  3655. return;
  3656. }
  3657. return ;
  3658. }
  3659. /*
  3660. * release all resource we used in allocation
  3661. */
  3662. static int ext4_mb_release_context(struct ext4_allocation_context *ac)
  3663. {
  3664. struct ext4_prealloc_space *pa = ac->ac_pa;
  3665. if (pa) {
  3666. if (pa->pa_type == MB_GROUP_PA) {
  3667. /* see comment in ext4_mb_use_group_pa() */
  3668. spin_lock(&pa->pa_lock);
  3669. pa->pa_pstart += ac->ac_b_ex.fe_len;
  3670. pa->pa_lstart += ac->ac_b_ex.fe_len;
  3671. pa->pa_free -= ac->ac_b_ex.fe_len;
  3672. pa->pa_len -= ac->ac_b_ex.fe_len;
  3673. spin_unlock(&pa->pa_lock);
  3674. }
  3675. }
  3676. if (ac->alloc_semp)
  3677. up_read(ac->alloc_semp);
  3678. if (pa) {
  3679. /*
  3680. * We want to add the pa to the right bucket.
  3681. * Remove it from the list and while adding
  3682. * make sure the list to which we are adding
  3683. * doesn't grow big. We need to release
  3684. * alloc_semp before calling ext4_mb_add_n_trim()
  3685. */
  3686. if ((pa->pa_type == MB_GROUP_PA) && likely(pa->pa_free)) {
  3687. spin_lock(pa->pa_obj_lock);
  3688. list_del_rcu(&pa->pa_inode_list);
  3689. spin_unlock(pa->pa_obj_lock);
  3690. ext4_mb_add_n_trim(ac);
  3691. }
  3692. ext4_mb_put_pa(ac, ac->ac_sb, pa);
  3693. }
  3694. if (ac->ac_bitmap_page)
  3695. page_cache_release(ac->ac_bitmap_page);
  3696. if (ac->ac_buddy_page)
  3697. page_cache_release(ac->ac_buddy_page);
  3698. if (ac->ac_flags & EXT4_MB_HINT_GROUP_ALLOC)
  3699. mutex_unlock(&ac->ac_lg->lg_mutex);
  3700. ext4_mb_collect_stats(ac);
  3701. return 0;
  3702. }
  3703. static int ext4_mb_discard_preallocations(struct super_block *sb, int needed)
  3704. {
  3705. ext4_group_t i, ngroups = ext4_get_groups_count(sb);
  3706. int ret;
  3707. int freed = 0;
  3708. trace_ext4_mb_discard_preallocations(sb, needed);
  3709. for (i = 0; i < ngroups && needed > 0; i++) {
  3710. ret = ext4_mb_discard_group_preallocations(sb, i, needed);
  3711. freed += ret;
  3712. needed -= ret;
  3713. }
  3714. return freed;
  3715. }
  3716. /*
  3717. * Main entry point into mballoc to allocate blocks
  3718. * it tries to use preallocation first, then falls back
  3719. * to usual allocation
  3720. */
  3721. ext4_fsblk_t ext4_mb_new_blocks(handle_t *handle,
  3722. struct ext4_allocation_request *ar, int *errp)
  3723. {
  3724. int freed;
  3725. struct ext4_allocation_context *ac = NULL;
  3726. struct ext4_sb_info *sbi;
  3727. struct super_block *sb;
  3728. ext4_fsblk_t block = 0;
  3729. unsigned int inquota = 0;
  3730. unsigned int reserv_blks = 0;
  3731. sb = ar->inode->i_sb;
  3732. sbi = EXT4_SB(sb);
  3733. trace_ext4_request_blocks(ar);
  3734. /*
  3735. * For delayed allocation, we could skip the ENOSPC and
  3736. * EDQUOT check, as blocks and quotas have been already
  3737. * reserved when data being copied into pagecache.
  3738. */
  3739. if (ext4_test_inode_state(ar->inode, EXT4_STATE_DELALLOC_RESERVED))
  3740. ar->flags |= EXT4_MB_DELALLOC_RESERVED;
  3741. else {
  3742. /* Without delayed allocation we need to verify
  3743. * there is enough free blocks to do block allocation
  3744. * and verify allocation doesn't exceed the quota limits.
  3745. */
  3746. while (ar->len && ext4_claim_free_blocks(sbi, ar->len)) {
  3747. /* let others to free the space */
  3748. yield();
  3749. ar->len = ar->len >> 1;
  3750. }
  3751. if (!ar->len) {
  3752. *errp = -ENOSPC;
  3753. return 0;
  3754. }
  3755. reserv_blks = ar->len;
  3756. while (ar->len && dquot_alloc_block(ar->inode, ar->len)) {
  3757. ar->flags |= EXT4_MB_HINT_NOPREALLOC;
  3758. ar->len--;
  3759. }
  3760. inquota = ar->len;
  3761. if (ar->len == 0) {
  3762. *errp = -EDQUOT;
  3763. goto out;
  3764. }
  3765. }
  3766. ac = kmem_cache_alloc(ext4_ac_cachep, GFP_NOFS);
  3767. if (!ac) {
  3768. ar->len = 0;
  3769. *errp = -ENOMEM;
  3770. goto out;
  3771. }
  3772. *errp = ext4_mb_initialize_context(ac, ar);
  3773. if (*errp) {
  3774. ar->len = 0;
  3775. goto out;
  3776. }
  3777. ac->ac_op = EXT4_MB_HISTORY_PREALLOC;
  3778. if (!ext4_mb_use_preallocated(ac)) {
  3779. ac->ac_op = EXT4_MB_HISTORY_ALLOC;
  3780. ext4_mb_normalize_request(ac, ar);
  3781. repeat:
  3782. /* allocate space in core */
  3783. *errp = ext4_mb_regular_allocator(ac);
  3784. if (*errp)
  3785. goto errout;
  3786. /* as we've just preallocated more space than
  3787. * user requested orinally, we store allocated
  3788. * space in a special descriptor */
  3789. if (ac->ac_status == AC_STATUS_FOUND &&
  3790. ac->ac_o_ex.fe_len < ac->ac_b_ex.fe_len)
  3791. ext4_mb_new_preallocation(ac);
  3792. }
  3793. if (likely(ac->ac_status == AC_STATUS_FOUND)) {
  3794. *errp = ext4_mb_mark_diskspace_used(ac, handle, reserv_blks);
  3795. if (*errp == -EAGAIN) {
  3796. /*
  3797. * drop the reference that we took
  3798. * in ext4_mb_use_best_found
  3799. */
  3800. ext4_mb_release_context(ac);
  3801. ac->ac_b_ex.fe_group = 0;
  3802. ac->ac_b_ex.fe_start = 0;
  3803. ac->ac_b_ex.fe_len = 0;
  3804. ac->ac_status = AC_STATUS_CONTINUE;
  3805. goto repeat;
  3806. } else if (*errp)
  3807. errout:
  3808. ext4_discard_allocated_blocks(ac);
  3809. else {
  3810. block = ext4_grp_offs_to_block(sb, &ac->ac_b_ex);
  3811. ar->len = ac->ac_b_ex.fe_len;
  3812. }
  3813. } else {
  3814. freed = ext4_mb_discard_preallocations(sb, ac->ac_o_ex.fe_len);
  3815. if (freed)
  3816. goto repeat;
  3817. *errp = -ENOSPC;
  3818. }
  3819. if (*errp) {
  3820. ac->ac_b_ex.fe_len = 0;
  3821. ar->len = 0;
  3822. ext4_mb_show_ac(ac);
  3823. }
  3824. ext4_mb_release_context(ac);
  3825. out:
  3826. if (ac)
  3827. kmem_cache_free(ext4_ac_cachep, ac);
  3828. if (inquota && ar->len < inquota)
  3829. dquot_free_block(ar->inode, inquota - ar->len);
  3830. if (!ar->len) {
  3831. if (!ext4_test_inode_state(ar->inode,
  3832. EXT4_STATE_DELALLOC_RESERVED))
  3833. /* release all the reserved blocks if non delalloc */
  3834. percpu_counter_sub(&sbi->s_dirtyblocks_counter,
  3835. reserv_blks);
  3836. }
  3837. trace_ext4_allocate_blocks(ar, (unsigned long long)block);
  3838. return block;
  3839. }
  3840. /*
  3841. * We can merge two free data extents only if the physical blocks
  3842. * are contiguous, AND the extents were freed by the same transaction,
  3843. * AND the blocks are associated with the same group.
  3844. */
  3845. static int can_merge(struct ext4_free_data *entry1,
  3846. struct ext4_free_data *entry2)
  3847. {
  3848. if ((entry1->t_tid == entry2->t_tid) &&
  3849. (entry1->group == entry2->group) &&
  3850. ((entry1->start_blk + entry1->count) == entry2->start_blk))
  3851. return 1;
  3852. return 0;
  3853. }
  3854. static noinline_for_stack int
  3855. ext4_mb_free_metadata(handle_t *handle, struct ext4_buddy *e4b,
  3856. struct ext4_free_data *new_entry)
  3857. {
  3858. ext4_group_t group = e4b->bd_group;
  3859. ext4_grpblk_t block;
  3860. struct ext4_free_data *entry;
  3861. struct ext4_group_info *db = e4b->bd_info;
  3862. struct super_block *sb = e4b->bd_sb;
  3863. struct ext4_sb_info *sbi = EXT4_SB(sb);
  3864. struct rb_node **n = &db->bb_free_root.rb_node, *node;
  3865. struct rb_node *parent = NULL, *new_node;
  3866. BUG_ON(!ext4_handle_valid(handle));
  3867. BUG_ON(e4b->bd_bitmap_page == NULL);
  3868. BUG_ON(e4b->bd_buddy_page == NULL);
  3869. new_node = &new_entry->node;
  3870. block = new_entry->start_blk;
  3871. if (!*n) {
  3872. /* first free block exent. We need to
  3873. protect buddy cache from being freed,
  3874. * otherwise we'll refresh it from
  3875. * on-disk bitmap and lose not-yet-available
  3876. * blocks */
  3877. page_cache_get(e4b->bd_buddy_page);
  3878. page_cache_get(e4b->bd_bitmap_page);
  3879. }
  3880. while (*n) {
  3881. parent = *n;
  3882. entry = rb_entry(parent, struct ext4_free_data, node);
  3883. if (block < entry->start_blk)
  3884. n = &(*n)->rb_left;
  3885. else if (block >= (entry->start_blk + entry->count))
  3886. n = &(*n)->rb_right;
  3887. else {
  3888. ext4_grp_locked_error(sb, group, 0,
  3889. ext4_group_first_block_no(sb, group) + block,
  3890. "Block already on to-be-freed list");
  3891. return 0;
  3892. }
  3893. }
  3894. rb_link_node(new_node, parent, n);
  3895. rb_insert_color(new_node, &db->bb_free_root);
  3896. /* Now try to see the extent can be merged to left and right */
  3897. node = rb_prev(new_node);
  3898. if (node) {
  3899. entry = rb_entry(node, struct ext4_free_data, node);
  3900. if (can_merge(entry, new_entry)) {
  3901. new_entry->start_blk = entry->start_blk;
  3902. new_entry->count += entry->count;
  3903. rb_erase(node, &(db->bb_free_root));
  3904. spin_lock(&sbi->s_md_lock);
  3905. list_del(&entry->list);
  3906. spin_unlock(&sbi->s_md_lock);
  3907. kmem_cache_free(ext4_free_ext_cachep, entry);
  3908. }
  3909. }
  3910. node = rb_next(new_node);
  3911. if (node) {
  3912. entry = rb_entry(node, struct ext4_free_data, node);
  3913. if (can_merge(new_entry, entry)) {
  3914. new_entry->count += entry->count;
  3915. rb_erase(node, &(db->bb_free_root));
  3916. spin_lock(&sbi->s_md_lock);
  3917. list_del(&entry->list);
  3918. spin_unlock(&sbi->s_md_lock);
  3919. kmem_cache_free(ext4_free_ext_cachep, entry);
  3920. }
  3921. }
  3922. /* Add the extent to transaction's private list */
  3923. spin_lock(&sbi->s_md_lock);
  3924. list_add(&new_entry->list, &handle->h_transaction->t_private_list);
  3925. spin_unlock(&sbi->s_md_lock);
  3926. return 0;
  3927. }
  3928. /**
  3929. * ext4_free_blocks() -- Free given blocks and update quota
  3930. * @handle: handle for this transaction
  3931. * @inode: inode
  3932. * @block: start physical block to free
  3933. * @count: number of blocks to count
  3934. * @metadata: Are these metadata blocks
  3935. */
  3936. void ext4_free_blocks(handle_t *handle, struct inode *inode,
  3937. struct buffer_head *bh, ext4_fsblk_t block,
  3938. unsigned long count, int flags)
  3939. {
  3940. struct buffer_head *bitmap_bh = NULL;
  3941. struct super_block *sb = inode->i_sb;
  3942. struct ext4_group_desc *gdp;
  3943. unsigned long freed = 0;
  3944. unsigned int overflow;
  3945. ext4_grpblk_t bit;
  3946. struct buffer_head *gd_bh;
  3947. ext4_group_t block_group;
  3948. struct ext4_sb_info *sbi;
  3949. struct ext4_buddy e4b;
  3950. int err = 0;
  3951. int ret;
  3952. if (bh) {
  3953. if (block)
  3954. BUG_ON(block != bh->b_blocknr);
  3955. else
  3956. block = bh->b_blocknr;
  3957. }
  3958. sbi = EXT4_SB(sb);
  3959. if (!(flags & EXT4_FREE_BLOCKS_VALIDATED) &&
  3960. !ext4_data_block_valid(sbi, block, count)) {
  3961. ext4_error(sb, "Freeing blocks not in datazone - "
  3962. "block = %llu, count = %lu", block, count);
  3963. goto error_return;
  3964. }
  3965. ext4_debug("freeing block %llu\n", block);
  3966. trace_ext4_free_blocks(inode, block, count, flags);
  3967. if (flags & EXT4_FREE_BLOCKS_FORGET) {
  3968. struct buffer_head *tbh = bh;
  3969. int i;
  3970. BUG_ON(bh && (count > 1));
  3971. for (i = 0; i < count; i++) {
  3972. if (!bh)
  3973. tbh = sb_find_get_block(inode->i_sb,
  3974. block + i);
  3975. if (unlikely(!tbh))
  3976. continue;
  3977. ext4_forget(handle, flags & EXT4_FREE_BLOCKS_METADATA,
  3978. inode, tbh, block + i);
  3979. }
  3980. }
  3981. /*
  3982. * We need to make sure we don't reuse the freed block until
  3983. * after the transaction is committed, which we can do by
  3984. * treating the block as metadata, below. We make an
  3985. * exception if the inode is to be written in writeback mode
  3986. * since writeback mode has weak data consistency guarantees.
  3987. */
  3988. if (!ext4_should_writeback_data(inode))
  3989. flags |= EXT4_FREE_BLOCKS_METADATA;
  3990. do_more:
  3991. overflow = 0;
  3992. ext4_get_group_no_and_offset(sb, block, &block_group, &bit);
  3993. /*
  3994. * Check to see if we are freeing blocks across a group
  3995. * boundary.
  3996. */
  3997. if (bit + count > EXT4_BLOCKS_PER_GROUP(sb)) {
  3998. overflow = bit + count - EXT4_BLOCKS_PER_GROUP(sb);
  3999. count -= overflow;
  4000. }
  4001. bitmap_bh = ext4_read_block_bitmap(sb, block_group);
  4002. if (!bitmap_bh) {
  4003. err = -EIO;
  4004. goto error_return;
  4005. }
  4006. gdp = ext4_get_group_desc(sb, block_group, &gd_bh);
  4007. if (!gdp) {
  4008. err = -EIO;
  4009. goto error_return;
  4010. }
  4011. if (in_range(ext4_block_bitmap(sb, gdp), block, count) ||
  4012. in_range(ext4_inode_bitmap(sb, gdp), block, count) ||
  4013. in_range(block, ext4_inode_table(sb, gdp),
  4014. EXT4_SB(sb)->s_itb_per_group) ||
  4015. in_range(block + count - 1, ext4_inode_table(sb, gdp),
  4016. EXT4_SB(sb)->s_itb_per_group)) {
  4017. ext4_error(sb, "Freeing blocks in system zone - "
  4018. "Block = %llu, count = %lu", block, count);
  4019. /* err = 0. ext4_std_error should be a no op */
  4020. goto error_return;
  4021. }
  4022. BUFFER_TRACE(bitmap_bh, "getting write access");
  4023. err = ext4_journal_get_write_access(handle, bitmap_bh);
  4024. if (err)
  4025. goto error_return;
  4026. /*
  4027. * We are about to modify some metadata. Call the journal APIs
  4028. * to unshare ->b_data if a currently-committing transaction is
  4029. * using it
  4030. */
  4031. BUFFER_TRACE(gd_bh, "get_write_access");
  4032. err = ext4_journal_get_write_access(handle, gd_bh);
  4033. if (err)
  4034. goto error_return;
  4035. #ifdef AGGRESSIVE_CHECK
  4036. {
  4037. int i;
  4038. for (i = 0; i < count; i++)
  4039. BUG_ON(!mb_test_bit(bit + i, bitmap_bh->b_data));
  4040. }
  4041. #endif
  4042. trace_ext4_mballoc_free(sb, inode, block_group, bit, count);
  4043. err = ext4_mb_load_buddy(sb, block_group, &e4b);
  4044. if (err)
  4045. goto error_return;
  4046. if ((flags & EXT4_FREE_BLOCKS_METADATA) && ext4_handle_valid(handle)) {
  4047. struct ext4_free_data *new_entry;
  4048. /*
  4049. * blocks being freed are metadata. these blocks shouldn't
  4050. * be used until this transaction is committed
  4051. */
  4052. new_entry = kmem_cache_alloc(ext4_free_ext_cachep, GFP_NOFS);
  4053. if (!new_entry) {
  4054. err = -ENOMEM;
  4055. goto error_return;
  4056. }
  4057. new_entry->start_blk = bit;
  4058. new_entry->group = block_group;
  4059. new_entry->count = count;
  4060. new_entry->t_tid = handle->h_transaction->t_tid;
  4061. ext4_lock_group(sb, block_group);
  4062. mb_clear_bits(bitmap_bh->b_data, bit, count);
  4063. ext4_mb_free_metadata(handle, &e4b, new_entry);
  4064. } else {
  4065. /* need to update group_info->bb_free and bitmap
  4066. * with group lock held. generate_buddy look at
  4067. * them with group lock_held
  4068. */
  4069. ext4_lock_group(sb, block_group);
  4070. mb_clear_bits(bitmap_bh->b_data, bit, count);
  4071. mb_free_blocks(inode, &e4b, bit, count);
  4072. }
  4073. ret = ext4_free_blks_count(sb, gdp) + count;
  4074. ext4_free_blks_set(sb, gdp, ret);
  4075. gdp->bg_checksum = ext4_group_desc_csum(sbi, block_group, gdp);
  4076. ext4_unlock_group(sb, block_group);
  4077. percpu_counter_add(&sbi->s_freeblocks_counter, count);
  4078. if (sbi->s_log_groups_per_flex) {
  4079. ext4_group_t flex_group = ext4_flex_group(sbi, block_group);
  4080. atomic_add(count, &sbi->s_flex_groups[flex_group].free_blocks);
  4081. }
  4082. ext4_mb_unload_buddy(&e4b);
  4083. freed += count;
  4084. /* We dirtied the bitmap block */
  4085. BUFFER_TRACE(bitmap_bh, "dirtied bitmap block");
  4086. err = ext4_handle_dirty_metadata(handle, NULL, bitmap_bh);
  4087. /* And the group descriptor block */
  4088. BUFFER_TRACE(gd_bh, "dirtied group descriptor block");
  4089. ret = ext4_handle_dirty_metadata(handle, NULL, gd_bh);
  4090. if (!err)
  4091. err = ret;
  4092. if (overflow && !err) {
  4093. block += count;
  4094. count = overflow;
  4095. put_bh(bitmap_bh);
  4096. goto do_more;
  4097. }
  4098. ext4_mark_super_dirty(sb);
  4099. error_return:
  4100. if (freed)
  4101. dquot_free_block(inode, freed);
  4102. brelse(bitmap_bh);
  4103. ext4_std_error(sb, err);
  4104. return;
  4105. }
  4106. /**
  4107. * ext4_add_groupblocks() -- Add given blocks to an existing group
  4108. * @handle: handle to this transaction
  4109. * @sb: super block
  4110. * @block: start physcial block to add to the block group
  4111. * @count: number of blocks to free
  4112. *
  4113. * This marks the blocks as free in the bitmap and buddy.
  4114. */
  4115. void ext4_add_groupblocks(handle_t *handle, struct super_block *sb,
  4116. ext4_fsblk_t block, unsigned long count)
  4117. {
  4118. struct buffer_head *bitmap_bh = NULL;
  4119. struct buffer_head *gd_bh;
  4120. ext4_group_t block_group;
  4121. ext4_grpblk_t bit;
  4122. unsigned int i;
  4123. struct ext4_group_desc *desc;
  4124. struct ext4_sb_info *sbi = EXT4_SB(sb);
  4125. struct ext4_buddy e4b;
  4126. int err = 0, ret, blk_free_count;
  4127. ext4_grpblk_t blocks_freed;
  4128. struct ext4_group_info *grp;
  4129. ext4_debug("Adding block(s) %llu-%llu\n", block, block + count - 1);
  4130. ext4_get_group_no_and_offset(sb, block, &block_group, &bit);
  4131. grp = ext4_get_group_info(sb, block_group);
  4132. /*
  4133. * Check to see if we are freeing blocks across a group
  4134. * boundary.
  4135. */
  4136. if (bit + count > EXT4_BLOCKS_PER_GROUP(sb))
  4137. goto error_return;
  4138. bitmap_bh = ext4_read_block_bitmap(sb, block_group);
  4139. if (!bitmap_bh)
  4140. goto error_return;
  4141. desc = ext4_get_group_desc(sb, block_group, &gd_bh);
  4142. if (!desc)
  4143. goto error_return;
  4144. if (in_range(ext4_block_bitmap(sb, desc), block, count) ||
  4145. in_range(ext4_inode_bitmap(sb, desc), block, count) ||
  4146. in_range(block, ext4_inode_table(sb, desc), sbi->s_itb_per_group) ||
  4147. in_range(block + count - 1, ext4_inode_table(sb, desc),
  4148. sbi->s_itb_per_group)) {
  4149. ext4_error(sb, "Adding blocks in system zones - "
  4150. "Block = %llu, count = %lu",
  4151. block, count);
  4152. goto error_return;
  4153. }
  4154. BUFFER_TRACE(bitmap_bh, "getting write access");
  4155. err = ext4_journal_get_write_access(handle, bitmap_bh);
  4156. if (err)
  4157. goto error_return;
  4158. /*
  4159. * We are about to modify some metadata. Call the journal APIs
  4160. * to unshare ->b_data if a currently-committing transaction is
  4161. * using it
  4162. */
  4163. BUFFER_TRACE(gd_bh, "get_write_access");
  4164. err = ext4_journal_get_write_access(handle, gd_bh);
  4165. if (err)
  4166. goto error_return;
  4167. for (i = 0, blocks_freed = 0; i < count; i++) {
  4168. BUFFER_TRACE(bitmap_bh, "clear bit");
  4169. if (!mb_test_bit(bit + i, bitmap_bh->b_data)) {
  4170. ext4_error(sb, "bit already cleared for block %llu",
  4171. (ext4_fsblk_t)(block + i));
  4172. BUFFER_TRACE(bitmap_bh, "bit already cleared");
  4173. } else {
  4174. blocks_freed++;
  4175. }
  4176. }
  4177. err = ext4_mb_load_buddy(sb, block_group, &e4b);
  4178. if (err)
  4179. goto error_return;
  4180. /*
  4181. * need to update group_info->bb_free and bitmap
  4182. * with group lock held. generate_buddy look at
  4183. * them with group lock_held
  4184. */
  4185. ext4_lock_group(sb, block_group);
  4186. mb_clear_bits(bitmap_bh->b_data, bit, count);
  4187. mb_free_blocks(NULL, &e4b, bit, count);
  4188. blk_free_count = blocks_freed + ext4_free_blks_count(sb, desc);
  4189. ext4_free_blks_set(sb, desc, blk_free_count);
  4190. desc->bg_checksum = ext4_group_desc_csum(sbi, block_group, desc);
  4191. ext4_unlock_group(sb, block_group);
  4192. percpu_counter_add(&sbi->s_freeblocks_counter, blocks_freed);
  4193. if (sbi->s_log_groups_per_flex) {
  4194. ext4_group_t flex_group = ext4_flex_group(sbi, block_group);
  4195. atomic_add(blocks_freed,
  4196. &sbi->s_flex_groups[flex_group].free_blocks);
  4197. }
  4198. ext4_mb_unload_buddy(&e4b);
  4199. /* We dirtied the bitmap block */
  4200. BUFFER_TRACE(bitmap_bh, "dirtied bitmap block");
  4201. err = ext4_handle_dirty_metadata(handle, NULL, bitmap_bh);
  4202. /* And the group descriptor block */
  4203. BUFFER_TRACE(gd_bh, "dirtied group descriptor block");
  4204. ret = ext4_handle_dirty_metadata(handle, NULL, gd_bh);
  4205. if (!err)
  4206. err = ret;
  4207. error_return:
  4208. brelse(bitmap_bh);
  4209. ext4_std_error(sb, err);
  4210. return;
  4211. }
  4212. /**
  4213. * ext4_trim_extent -- function to TRIM one single free extent in the group
  4214. * @sb: super block for the file system
  4215. * @start: starting block of the free extent in the alloc. group
  4216. * @count: number of blocks to TRIM
  4217. * @group: alloc. group we are working with
  4218. * @e4b: ext4 buddy for the group
  4219. *
  4220. * Trim "count" blocks starting at "start" in the "group". To assure that no
  4221. * one will allocate those blocks, mark it as used in buddy bitmap. This must
  4222. * be called with under the group lock.
  4223. */
  4224. static void ext4_trim_extent(struct super_block *sb, int start, int count,
  4225. ext4_group_t group, struct ext4_buddy *e4b)
  4226. {
  4227. struct ext4_free_extent ex;
  4228. assert_spin_locked(ext4_group_lock_ptr(sb, group));
  4229. ex.fe_start = start;
  4230. ex.fe_group = group;
  4231. ex.fe_len = count;
  4232. /*
  4233. * Mark blocks used, so no one can reuse them while
  4234. * being trimmed.
  4235. */
  4236. mb_mark_used(e4b, &ex);
  4237. ext4_unlock_group(sb, group);
  4238. ext4_issue_discard(sb, group, start, count);
  4239. ext4_lock_group(sb, group);
  4240. mb_free_blocks(NULL, e4b, start, ex.fe_len);
  4241. }
  4242. /**
  4243. * ext4_trim_all_free -- function to trim all free space in alloc. group
  4244. * @sb: super block for file system
  4245. * @e4b: ext4 buddy
  4246. * @start: first group block to examine
  4247. * @max: last group block to examine
  4248. * @minblocks: minimum extent block count
  4249. *
  4250. * ext4_trim_all_free walks through group's buddy bitmap searching for free
  4251. * extents. When the free block is found, ext4_trim_extent is called to TRIM
  4252. * the extent.
  4253. *
  4254. *
  4255. * ext4_trim_all_free walks through group's block bitmap searching for free
  4256. * extents. When the free extent is found, mark it as used in group buddy
  4257. * bitmap. Then issue a TRIM command on this extent and free the extent in
  4258. * the group buddy bitmap. This is done until whole group is scanned.
  4259. */
  4260. static ext4_grpblk_t
  4261. ext4_trim_all_free(struct super_block *sb, struct ext4_buddy *e4b,
  4262. ext4_grpblk_t start, ext4_grpblk_t max, ext4_grpblk_t minblocks)
  4263. {
  4264. void *bitmap;
  4265. ext4_grpblk_t next, count = 0;
  4266. ext4_group_t group;
  4267. BUG_ON(e4b == NULL);
  4268. bitmap = e4b->bd_bitmap;
  4269. group = e4b->bd_group;
  4270. start = (e4b->bd_info->bb_first_free > start) ?
  4271. e4b->bd_info->bb_first_free : start;
  4272. ext4_lock_group(sb, group);
  4273. while (start < max) {
  4274. start = mb_find_next_zero_bit(bitmap, max, start);
  4275. if (start >= max)
  4276. break;
  4277. next = mb_find_next_bit(bitmap, max, start);
  4278. if ((next - start) >= minblocks) {
  4279. ext4_trim_extent(sb, start,
  4280. next - start, group, e4b);
  4281. count += next - start;
  4282. }
  4283. start = next + 1;
  4284. if (fatal_signal_pending(current)) {
  4285. count = -ERESTARTSYS;
  4286. break;
  4287. }
  4288. if (need_resched()) {
  4289. ext4_unlock_group(sb, group);
  4290. cond_resched();
  4291. ext4_lock_group(sb, group);
  4292. }
  4293. if ((e4b->bd_info->bb_free - count) < minblocks)
  4294. break;
  4295. }
  4296. ext4_unlock_group(sb, group);
  4297. ext4_debug("trimmed %d blocks in the group %d\n",
  4298. count, group);
  4299. return count;
  4300. }
  4301. /**
  4302. * ext4_trim_fs() -- trim ioctl handle function
  4303. * @sb: superblock for filesystem
  4304. * @range: fstrim_range structure
  4305. *
  4306. * start: First Byte to trim
  4307. * len: number of Bytes to trim from start
  4308. * minlen: minimum extent length in Bytes
  4309. * ext4_trim_fs goes through all allocation groups containing Bytes from
  4310. * start to start+len. For each such a group ext4_trim_all_free function
  4311. * is invoked to trim all free space.
  4312. */
  4313. int ext4_trim_fs(struct super_block *sb, struct fstrim_range *range)
  4314. {
  4315. struct ext4_buddy e4b;
  4316. ext4_group_t first_group, last_group;
  4317. ext4_group_t group, ngroups = ext4_get_groups_count(sb);
  4318. ext4_grpblk_t cnt = 0, first_block, last_block;
  4319. uint64_t start, len, minlen, trimmed;
  4320. ext4_fsblk_t first_data_blk =
  4321. le32_to_cpu(EXT4_SB(sb)->s_es->s_first_data_block);
  4322. int ret = 0;
  4323. start = range->start >> sb->s_blocksize_bits;
  4324. len = range->len >> sb->s_blocksize_bits;
  4325. minlen = range->minlen >> sb->s_blocksize_bits;
  4326. trimmed = 0;
  4327. if (unlikely(minlen > EXT4_BLOCKS_PER_GROUP(sb)))
  4328. return -EINVAL;
  4329. if (start < first_data_blk) {
  4330. len -= first_data_blk - start;
  4331. start = first_data_blk;
  4332. }
  4333. /* Determine first and last group to examine based on start and len */
  4334. ext4_get_group_no_and_offset(sb, (ext4_fsblk_t) start,
  4335. &first_group, &first_block);
  4336. ext4_get_group_no_and_offset(sb, (ext4_fsblk_t) (start + len),
  4337. &last_group, &last_block);
  4338. last_group = (last_group > ngroups - 1) ? ngroups - 1 : last_group;
  4339. last_block = EXT4_BLOCKS_PER_GROUP(sb);
  4340. if (first_group > last_group)
  4341. return -EINVAL;
  4342. for (group = first_group; group <= last_group; group++) {
  4343. ret = ext4_mb_load_buddy(sb, group, &e4b);
  4344. if (ret) {
  4345. ext4_error(sb, "Error in loading buddy "
  4346. "information for %u", group);
  4347. break;
  4348. }
  4349. /*
  4350. * For all the groups except the last one, last block will
  4351. * always be EXT4_BLOCKS_PER_GROUP(sb), so we only need to
  4352. * change it for the last group in which case start +
  4353. * len < EXT4_BLOCKS_PER_GROUP(sb).
  4354. */
  4355. if (first_block + len < EXT4_BLOCKS_PER_GROUP(sb))
  4356. last_block = first_block + len;
  4357. len -= last_block - first_block;
  4358. if (e4b.bd_info->bb_free >= minlen) {
  4359. cnt = ext4_trim_all_free(sb, &e4b, first_block,
  4360. last_block, minlen);
  4361. if (cnt < 0) {
  4362. ret = cnt;
  4363. ext4_mb_unload_buddy(&e4b);
  4364. break;
  4365. }
  4366. }
  4367. ext4_mb_unload_buddy(&e4b);
  4368. trimmed += cnt;
  4369. first_block = 0;
  4370. }
  4371. range->len = trimmed * sb->s_blocksize;
  4372. return ret;
  4373. }