lfs.c 141 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681368236833684368536863687368836893690369136923693369436953696369736983699370037013702370337043705370637073708370937103711371237133714371537163717371837193720372137223723372437253726372737283729373037313732373337343735373637373738373937403741374237433744374537463747374837493750375137523753375437553756375737583759376037613762376337643765376637673768376937703771377237733774377537763777377837793780378137823783378437853786378737883789379037913792379337943795379637973798379938003801380238033804380538063807380838093810381138123813381438153816381738183819382038213822382338243825382638273828382938303831383238333834383538363837383838393840384138423843384438453846384738483849385038513852385338543855385638573858385938603861386238633864386538663867386838693870387138723873387438753876387738783879388038813882388338843885388638873888388938903891389238933894389538963897389838993900390139023903390439053906390739083909391039113912391339143915391639173918391939203921392239233924392539263927392839293930393139323933393439353936393739383939394039413942394339443945394639473948394939503951395239533954395539563957395839593960396139623963396439653966396739683969397039713972397339743975397639773978397939803981398239833984398539863987398839893990399139923993399439953996399739983999400040014002400340044005400640074008400940104011401240134014401540164017401840194020402140224023402440254026402740284029403040314032403340344035403640374038403940404041404240434044404540464047404840494050405140524053405440554056405740584059406040614062406340644065406640674068406940704071407240734074407540764077407840794080408140824083408440854086408740884089409040914092409340944095409640974098409941004101410241034104410541064107410841094110411141124113411441154116411741184119412041214122412341244125412641274128412941304131413241334134413541364137413841394140414141424143414441454146414741484149415041514152415341544155415641574158415941604161416241634164416541664167416841694170417141724173417441754176417741784179418041814182418341844185418641874188418941904191419241934194419541964197419841994200420142024203420442054206420742084209421042114212421342144215421642174218421942204221422242234224422542264227422842294230423142324233423442354236423742384239424042414242424342444245424642474248424942504251425242534254425542564257425842594260426142624263426442654266426742684269427042714272427342744275427642774278427942804281428242834284428542864287428842894290429142924293429442954296429742984299430043014302430343044305430643074308430943104311431243134314431543164317431843194320432143224323432443254326432743284329433043314332433343344335433643374338433943404341434243434344434543464347434843494350435143524353435443554356435743584359436043614362436343644365436643674368436943704371437243734374437543764377437843794380438143824383438443854386438743884389439043914392439343944395439643974398439944004401440244034404440544064407440844094410441144124413441444154416441744184419442044214422442344244425442644274428442944304431443244334434443544364437443844394440444144424443444444454446444744484449445044514452445344544455445644574458445944604461446244634464446544664467446844694470447144724473447444754476447744784479448044814482448344844485448644874488448944904491449244934494449544964497449844994500450145024503450445054506450745084509451045114512451345144515451645174518451945204521452245234524452545264527452845294530453145324533453445354536453745384539454045414542454345444545454645474548454945504551455245534554455545564557455845594560456145624563456445654566456745684569457045714572457345744575457645774578457945804581458245834584458545864587458845894590459145924593459445954596459745984599460046014602460346044605460646074608460946104611461246134614461546164617461846194620462146224623462446254626462746284629463046314632463346344635463646374638463946404641464246434644464546464647464846494650465146524653465446554656465746584659466046614662466346644665466646674668466946704671467246734674467546764677467846794680468146824683468446854686468746884689469046914692469346944695469646974698469947004701470247034704470547064707470847094710471147124713471447154716471747184719472047214722472347244725472647274728472947304731473247334734473547364737473847394740474147424743474447454746474747484749475047514752475347544755475647574758475947604761476247634764476547664767476847694770477147724773477447754776477747784779478047814782478347844785478647874788478947904791479247934794479547964797479847994800480148024803480448054806480748084809481048114812481348144815481648174818481948204821482248234824482548264827482848294830483148324833483448354836483748384839484048414842484348444845484648474848484948504851485248534854485548564857485848594860486148624863486448654866486748684869487048714872487348744875487648774878487948804881488248834884488548864887488848894890489148924893489448954896489748984899490049014902490349044905490649074908490949104911491249134914491549164917491849194920492149224923492449254926492749284929493049314932493349344935493649374938493949404941494249434944494549464947494849494950495149524953495449554956495749584959496049614962496349644965496649674968496949704971497249734974497549764977497849794980498149824983498449854986498749884989499049914992499349944995499649974998499950005001500250035004500550065007500850095010501150125013501450155016501750185019502050215022
  1. /*
  2. * The little filesystem
  3. *
  4. * Copyright (c) 2017 ARM Limited
  5. *
  6. * Licensed under the Apache License, Version 2.0 (the "License");
  7. * you may not use this file except in compliance with the License.
  8. * You may obtain a copy of the License at
  9. *
  10. * http://www.apache.org/licenses/LICENSE-2.0
  11. *
  12. * Unless required by applicable law or agreed to in writing, software
  13. * distributed under the License is distributed on an "AS IS" BASIS,
  14. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15. * See the License for the specific language governing permissions and
  16. * limitations under the License.
  17. */
  18. #include "lfs.h"
  19. #include "lfs_util.h"
  20. /// Caching block device operations ///
  21. static int lfs_cache_read(lfs_t *lfs, lfs_cache_t *rcache,
  22. const lfs_cache_t *pcache, lfs_block_t block,
  23. lfs_off_t off, void *buffer, lfs_size_t size) {
  24. uint8_t *data = buffer;
  25. LFS_ASSERT(block != 0xffffffff);
  26. while (size > 0) {
  27. if (pcache && block == pcache->block && off >= pcache->off &&
  28. off < pcache->off + lfs->cfg->prog_size) {
  29. // is already in pcache?
  30. lfs_size_t diff = lfs_min(size,
  31. lfs->cfg->prog_size - (off-pcache->off));
  32. memcpy(data, &pcache->buffer[off-pcache->off], diff);
  33. data += diff;
  34. off += diff;
  35. size -= diff;
  36. continue;
  37. }
  38. if (block == rcache->block && off >= rcache->off &&
  39. off < rcache->off + lfs->cfg->read_size) {
  40. // is already in rcache?
  41. lfs_size_t diff = lfs_min(size,
  42. lfs->cfg->read_size - (off-rcache->off));
  43. memcpy(data, &rcache->buffer[off-rcache->off], diff);
  44. data += diff;
  45. off += diff;
  46. size -= diff;
  47. continue;
  48. }
  49. if (off % lfs->cfg->read_size == 0 && size >= lfs->cfg->read_size) {
  50. // bypass cache?
  51. lfs_size_t diff = size - (size % lfs->cfg->read_size);
  52. int err = lfs->cfg->read(lfs->cfg, block, off, data, diff);
  53. if (err) {
  54. return err;
  55. }
  56. data += diff;
  57. off += diff;
  58. size -= diff;
  59. continue;
  60. }
  61. // load to cache, first condition can no longer fail
  62. LFS_ASSERT(block < lfs->cfg->block_count);
  63. rcache->block = block;
  64. rcache->off = off - (off % lfs->cfg->read_size);
  65. int err = lfs->cfg->read(lfs->cfg, rcache->block,
  66. rcache->off, rcache->buffer, lfs->cfg->read_size);
  67. if (err) {
  68. return err;
  69. }
  70. }
  71. return 0;
  72. }
  73. static int lfs_cache_cmp(lfs_t *lfs, lfs_cache_t *rcache,
  74. const lfs_cache_t *pcache, lfs_block_t block,
  75. lfs_off_t off, const void *buffer, lfs_size_t size) {
  76. const uint8_t *data = buffer;
  77. for (lfs_off_t i = 0; i < size; i++) {
  78. uint8_t c;
  79. int err = lfs_cache_read(lfs, rcache, pcache,
  80. block, off+i, &c, 1);
  81. if (err) {
  82. return err;
  83. }
  84. if (c != data[i]) {
  85. return false;
  86. }
  87. }
  88. return true;
  89. }
  90. static int lfs_cache_crc(lfs_t *lfs, lfs_cache_t *rcache,
  91. const lfs_cache_t *pcache, lfs_block_t block,
  92. lfs_off_t off, lfs_size_t size, uint32_t *crc) {
  93. for (lfs_off_t i = 0; i < size; i++) {
  94. uint8_t c;
  95. int err = lfs_cache_read(lfs, rcache, pcache,
  96. block, off+i, &c, 1);
  97. if (err) {
  98. return err;
  99. }
  100. lfs_crc(crc, &c, 1);
  101. }
  102. return 0;
  103. }
  104. static int lfs_cache_flush(lfs_t *lfs,
  105. lfs_cache_t *pcache, lfs_cache_t *rcache) {
  106. if (pcache->block != 0xffffffff) {
  107. LFS_ASSERT(pcache->block < lfs->cfg->block_count);
  108. int err = lfs->cfg->prog(lfs->cfg, pcache->block,
  109. pcache->off, pcache->buffer, lfs->cfg->prog_size);
  110. if (err) {
  111. return err;
  112. }
  113. if (rcache) {
  114. int res = lfs_cache_cmp(lfs, rcache, NULL, pcache->block,
  115. pcache->off, pcache->buffer, lfs->cfg->prog_size);
  116. if (res < 0) {
  117. return res;
  118. }
  119. if (!res) {
  120. return LFS_ERR_CORRUPT;
  121. }
  122. }
  123. pcache->block = 0xffffffff;
  124. }
  125. return 0;
  126. }
  127. static int lfs_cache_prog(lfs_t *lfs, lfs_cache_t *pcache,
  128. lfs_cache_t *rcache, lfs_block_t block,
  129. lfs_off_t off, const void *buffer, lfs_size_t size) {
  130. const uint8_t *data = buffer;
  131. LFS_ASSERT(block != 0xffffffff);
  132. LFS_ASSERT(off + size <= lfs->cfg->block_size);
  133. while (size > 0) {
  134. if (block == pcache->block && off >= pcache->off &&
  135. off < pcache->off + lfs->cfg->prog_size) {
  136. // is already in pcache?
  137. lfs_size_t diff = lfs_min(size,
  138. lfs->cfg->prog_size - (off-pcache->off));
  139. memcpy(&pcache->buffer[off-pcache->off], data, diff);
  140. data += diff;
  141. off += diff;
  142. size -= diff;
  143. if (off % lfs->cfg->prog_size == 0) {
  144. // eagerly flush out pcache if we fill up
  145. int err = lfs_cache_flush(lfs, pcache, rcache);
  146. if (err) {
  147. return err;
  148. }
  149. }
  150. continue;
  151. }
  152. // pcache must have been flushed, either by programming and
  153. // entire block or manually flushing the pcache
  154. LFS_ASSERT(pcache->block == 0xffffffff);
  155. if (off % lfs->cfg->prog_size == 0 &&
  156. size >= lfs->cfg->prog_size) {
  157. // bypass pcache?
  158. LFS_ASSERT(block < lfs->cfg->block_count);
  159. lfs_size_t diff = size - (size % lfs->cfg->prog_size);
  160. int err = lfs->cfg->prog(lfs->cfg, block, off, data, diff);
  161. if (err) {
  162. return err;
  163. }
  164. if (rcache) {
  165. int res = lfs_cache_cmp(lfs, rcache, NULL,
  166. block, off, data, diff);
  167. if (res < 0) {
  168. return res;
  169. }
  170. if (!res) {
  171. return LFS_ERR_CORRUPT;
  172. }
  173. }
  174. data += diff;
  175. off += diff;
  176. size -= diff;
  177. continue;
  178. }
  179. // prepare pcache, first condition can no longer fail
  180. pcache->block = block;
  181. pcache->off = off - (off % lfs->cfg->prog_size);
  182. }
  183. return 0;
  184. }
  185. /// General lfs block device operations ///
  186. static int lfs_bd_read(lfs_t *lfs, lfs_block_t block,
  187. lfs_off_t off, void *buffer, lfs_size_t size) {
  188. return lfs_cache_read(lfs, &lfs->rcache, &lfs->pcache,
  189. block, off, buffer, size);
  190. }
  191. static int lfs_bd_prog(lfs_t *lfs, lfs_block_t block,
  192. lfs_off_t off, const void *buffer, lfs_size_t size) {
  193. return lfs_cache_prog(lfs, &lfs->pcache, NULL,
  194. block, off, buffer, size);
  195. }
  196. static int lfs_bd_cmp(lfs_t *lfs, lfs_block_t block,
  197. lfs_off_t off, const void *buffer, lfs_size_t size) {
  198. return lfs_cache_cmp(lfs, &lfs->rcache, NULL, block, off, buffer, size);
  199. }
  200. static int lfs_bd_crc(lfs_t *lfs, lfs_block_t block,
  201. lfs_off_t off, lfs_size_t size, uint32_t *crc) {
  202. return lfs_cache_crc(lfs, &lfs->rcache, NULL, block, off, size, crc);
  203. }
  204. static int lfs_bd_erase(lfs_t *lfs, lfs_block_t block) {
  205. LFS_ASSERT(block < lfs->cfg->block_count);
  206. return lfs->cfg->erase(lfs->cfg, block);
  207. }
  208. static int lfs_bd_sync(lfs_t *lfs) {
  209. lfs->rcache.block = 0xffffffff;
  210. int err = lfs_cache_flush(lfs, &lfs->pcache, NULL);
  211. if (err) {
  212. return err;
  213. }
  214. return lfs->cfg->sync(lfs->cfg);
  215. }
  216. /// Internal operations predeclared here ///
  217. int lfs_fs_traverse(lfs_t *lfs,
  218. int (*cb)(lfs_t*, void*, lfs_block_t), void *data);
  219. static int lfs_pred(lfs_t *lfs, const lfs_block_t dir[2], lfs_dir_t *pdir);
  220. static int lfs_parent(lfs_t *lfs, const lfs_block_t dir[2],
  221. lfs_dir_t *parent, lfs_entry_t *entry);
  222. static int lfs_moved(lfs_t *lfs, lfs_dir_t *fromdir, uint16_t fromid);
  223. static int lfs_relocate(lfs_t *lfs,
  224. const lfs_block_t oldpair[2], const lfs_block_t newpair[2]);
  225. int lfs_deorphan(lfs_t *lfs);
  226. /// Block allocator ///
  227. static int lfs_alloc_lookahead(lfs_t *lfs, void *p, lfs_block_t block) {
  228. lfs_block_t off = ((block - lfs->free.off)
  229. + lfs->cfg->block_count) % lfs->cfg->block_count;
  230. if (off < lfs->free.size) {
  231. lfs->free.buffer[off / 32] |= 1U << (off % 32);
  232. }
  233. return 0;
  234. }
  235. static int lfs_alloc(lfs_t *lfs, lfs_block_t *block) {
  236. while (true) {
  237. while (lfs->free.i != lfs->free.size) {
  238. lfs_block_t off = lfs->free.i;
  239. lfs->free.i += 1;
  240. lfs->free.ack -= 1;
  241. if (!(lfs->free.buffer[off / 32] & (1U << (off % 32)))) {
  242. // found a free block
  243. *block = (lfs->free.off + off) % lfs->cfg->block_count;
  244. // eagerly find next off so an alloc ack can
  245. // discredit old lookahead blocks
  246. while (lfs->free.i != lfs->free.size &&
  247. (lfs->free.buffer[lfs->free.i / 32]
  248. & (1U << (lfs->free.i % 32)))) {
  249. lfs->free.i += 1;
  250. lfs->free.ack -= 1;
  251. }
  252. return 0;
  253. }
  254. }
  255. // check if we have looked at all blocks since last ack
  256. if (lfs->free.ack == 0) {
  257. LFS_WARN("No more free space %d", lfs->free.i + lfs->free.off);
  258. return LFS_ERR_NOSPC;
  259. }
  260. lfs->free.off = (lfs->free.off + lfs->free.size)
  261. % lfs->cfg->block_count;
  262. lfs->free.size = lfs_min(lfs->cfg->lookahead, lfs->free.ack);
  263. lfs->free.i = 0;
  264. // find mask of free blocks from tree
  265. memset(lfs->free.buffer, 0, lfs->cfg->lookahead/8);
  266. int err = lfs_fs_traverse(lfs, lfs_alloc_lookahead, NULL);
  267. if (err) {
  268. return err;
  269. }
  270. }
  271. }
  272. static void lfs_alloc_ack(lfs_t *lfs) {
  273. lfs->free.ack = lfs->cfg->block_count;
  274. }
  275. /// Endian swapping functions ///
  276. //static void lfs_dir_fromle32(struct lfs_disk_dir *d) {
  277. // d->rev = lfs_fromle32(d->rev);
  278. // d->size = lfs_fromle32(d->size);
  279. // d->tail[0] = lfs_fromle32(d->tail[0]);
  280. // d->tail[1] = lfs_fromle32(d->tail[1]);
  281. //}
  282. //
  283. //static void lfs_dir_tole32(struct lfs_disk_dir *d) {
  284. // d->rev = lfs_tole32(d->rev);
  285. // d->size = lfs_tole32(d->size);
  286. // d->tail[0] = lfs_tole32(d->tail[0]);
  287. // d->tail[1] = lfs_tole32(d->tail[1]);
  288. //}
  289. //
  290. //static void lfs_entry_fromle32(struct lfs_disk_entry *d) {
  291. // d->u.dir[0] = lfs_fromle32(d->u.dir[0]);
  292. // d->u.dir[1] = lfs_fromle32(d->u.dir[1]);
  293. //}
  294. //
  295. //static void lfs_entry_tole32(struct lfs_disk_entry *d) {
  296. // d->u.dir[0] = lfs_tole32(d->u.dir[0]);
  297. // d->u.dir[1] = lfs_tole32(d->u.dir[1]);
  298. //}
  299. ///*static*/ void lfs_superblock_fromle32(struct lfs_disk_superblock *d) {
  300. // d->root[0] = lfs_fromle32(d->root[0]);
  301. // d->root[1] = lfs_fromle32(d->root[1]);
  302. // d->block_size = lfs_fromle32(d->block_size);
  303. // d->block_count = lfs_fromle32(d->block_count);
  304. // d->version = lfs_fromle32(d->version);
  305. // d->inline_size = lfs_fromle32(d->inline_size);
  306. // d->attrs_size = lfs_fromle32(d->attrs_size);
  307. // d->name_size = lfs_fromle32(d->name_size);
  308. //}
  309. //
  310. ///*static*/ void lfs_superblock_tole32(struct lfs_disk_superblock *d) {
  311. // d->root[0] = lfs_tole32(d->root[0]);
  312. // d->root[1] = lfs_tole32(d->root[1]);
  313. // d->block_size = lfs_tole32(d->block_size);
  314. // d->block_count = lfs_tole32(d->block_count);
  315. // d->version = lfs_tole32(d->version);
  316. // d->inline_size = lfs_tole32(d->inline_size);
  317. // d->attrs_size = lfs_tole32(d->attrs_size);
  318. // d->name_size = lfs_tole32(d->name_size);
  319. //}
  320. /// Other struct functions ///
  321. //static inline lfs_size_t lfs_entry_elen(const lfs_entry_t *entry) {
  322. // return (lfs_size_t)(entry->d.elen) |
  323. // ((lfs_size_t)(entry->d.alen & 0xc0) << 2);
  324. //}
  325. //
  326. //static inline lfs_size_t lfs_entry_alen(const lfs_entry_t *entry) {
  327. // return entry->d.alen & 0x3f;
  328. //}
  329. //
  330. //static inline lfs_size_t lfs_entry_nlen(const lfs_entry_t *entry) {
  331. // return entry->d.nlen;
  332. //}
  333. //
  334. //static inline lfs_size_t lfs_entry_size(const lfs_entry_t *entry) {
  335. // return 4 + lfs_entry_elen(entry) +
  336. // lfs_entry_alen(entry) +
  337. // lfs_entry_nlen(entry);
  338. //}
  339. /// Metadata pair and directory operations ///
  340. static inline void lfs_pairswap(lfs_block_t pair[2]) {
  341. lfs_block_t t = pair[0];
  342. pair[0] = pair[1];
  343. pair[1] = t;
  344. }
  345. static inline bool lfs_pairisnull(const lfs_block_t pair[2]) {
  346. return pair[0] == 0xffffffff || pair[1] == 0xffffffff;
  347. }
  348. static inline int lfs_paircmp(
  349. const lfs_block_t paira[2],
  350. const lfs_block_t pairb[2]) {
  351. return !(paira[0] == pairb[0] || paira[1] == pairb[1] ||
  352. paira[0] == pairb[1] || paira[1] == pairb[0]);
  353. }
  354. static inline bool lfs_pairsync(
  355. const lfs_block_t paira[2],
  356. const lfs_block_t pairb[2]) {
  357. return (paira[0] == pairb[0] && paira[1] == pairb[1]) ||
  358. (paira[0] == pairb[1] && paira[1] == pairb[0]);
  359. }
  360. /// Entry tag operations ///
  361. static inline lfs_tag_t lfs_mktag(
  362. uint16_t type, uint16_t id, lfs_size_t size) {
  363. return (type << 22) | (id << 12) | size;
  364. }
  365. static inline bool lfs_tag_valid(lfs_tag_t tag) {
  366. return !(tag & 0x80000000);
  367. }
  368. static inline uint16_t lfs_tag_type(lfs_tag_t tag) {
  369. return (tag & 0x7fc00000) >> 22;
  370. }
  371. static inline uint8_t lfs_tag_supertype(lfs_tag_t tag) {
  372. return (tag & 0x70000000) >> 22;
  373. }
  374. static inline uint8_t lfs_tag_subtype(lfs_tag_t tag) {
  375. return (tag & 0x7c000000) >> 22;
  376. }
  377. static inline uint8_t lfs_tag_struct(lfs_tag_t tag) {
  378. return (tag & 0x03c00000) >> 22;
  379. }
  380. static inline uint16_t lfs_tag_id(lfs_tag_t tag) {
  381. return (tag & 0x001ff000) >> 12;
  382. }
  383. static inline lfs_size_t lfs_tag_size(lfs_tag_t tag) {
  384. return tag & 0x00000fff;
  385. }
  386. struct lfs_commit {
  387. lfs_block_t block;
  388. lfs_off_t off;
  389. lfs_off_t begin;
  390. lfs_off_t end;
  391. lfs_tag_t ptag;
  392. uint32_t crc;
  393. struct {
  394. uint16_t begin;
  395. uint16_t end;
  396. } filter;
  397. };
  398. // TODO predelcare
  399. static int lfs_commit_move_(lfs_t *lfs, struct lfs_commit *commit,
  400. lfs_entry_t entry);
  401. //static int lfs_commit_compactcheck(lfs_t *lfs, void *p, lfs_entry_t entry) {
  402. // struct lfs_commit *commit = p;
  403. // if (lfs_tag_id(entry.tag) != commit->compact.id) {
  404. // return 1;
  405. // } else if (lfs_tag_type(entry.tag) == commit->compact.type) {
  406. // return 2;
  407. // }
  408. //
  409. // return 0;
  410. //}
  411. //
  412. static int lfs_commit_commit(lfs_t *lfs,
  413. struct lfs_commit *commit, lfs_entry_t entry) {
  414. // filter out ids
  415. if (lfs_tag_id(entry.tag) != 0x1ff && (
  416. lfs_tag_id(entry.tag) < commit->filter.begin ||
  417. lfs_tag_id(entry.tag) >= commit->filter.end)) {
  418. return 0;
  419. }
  420. // special cases
  421. if ((lfs_tag_type(entry.tag) & 0x103) == LFS_FROM_MOVE) {
  422. return lfs_commit_move_(lfs, commit, entry);
  423. }
  424. uint16_t id = lfs_tag_id(entry.tag) - commit->filter.begin;
  425. entry.tag = lfs_mktag(0, id, 0) | (entry.tag & 0xffe00fff);
  426. // check if we fit
  427. lfs_size_t size = lfs_tag_size(entry.tag);
  428. if (commit->off + sizeof(lfs_tag_t)+size > commit->end) {
  429. return LFS_ERR_NOSPC;
  430. }
  431. // write out tag
  432. // TODO rm me
  433. //printf("tag w %#010x (%x:%x %03x %03x %03x)\n", entry.tag, commit->block, commit->off+sizeof(lfs_tag_t), lfs_tag_type(entry.tag), lfs_tag_id(entry.tag), lfs_tag_size(entry.tag));
  434. lfs_tag_t tag = lfs_tole32((entry.tag & 0x7fffffff) ^ commit->ptag);
  435. lfs_crc(&commit->crc, &tag, sizeof(tag));
  436. int err = lfs_bd_prog(lfs, commit->block, commit->off, &tag, sizeof(tag));
  437. if (err) {
  438. return err;
  439. }
  440. commit->off += sizeof(tag);
  441. if (!(entry.tag & 0x80000000)) {
  442. // from memory
  443. lfs_crc(&commit->crc, entry.u.buffer, size);
  444. err = lfs_bd_prog(lfs, commit->block, commit->off,
  445. entry.u.buffer, size);
  446. if (err) {
  447. return err;
  448. }
  449. } else {
  450. // from disk
  451. for (lfs_off_t i = 0; i < size; i++) {
  452. uint8_t dat;
  453. int err = lfs_bd_read(lfs,
  454. entry.u.d.block, entry.u.d.off+i, &dat, 1);
  455. if (err) {
  456. return err;
  457. }
  458. lfs_crc(&commit->crc, &dat, 1);
  459. err = lfs_bd_prog(lfs, commit->block, commit->off+i, &dat, 1);
  460. if (err) {
  461. return err;
  462. }
  463. }
  464. }
  465. commit->off += size;
  466. commit->ptag = entry.tag & 0x7fffffff; // TODO do this once
  467. return 0;
  468. }
  469. static int lfs_commit_crc(lfs_t *lfs, struct lfs_commit *commit) {
  470. // align to program units
  471. lfs_off_t noff = lfs_alignup(
  472. commit->off + 2*sizeof(uint32_t), lfs->cfg->prog_size);
  473. // read erased state from next program unit
  474. lfs_tag_t tag;
  475. int err = lfs_bd_read(lfs, commit->block, noff, &tag, sizeof(tag));
  476. if (err) {
  477. return err;
  478. }
  479. // build crc tag
  480. tag = (0x80000000 & ~lfs_fromle32(tag)) |
  481. lfs_mktag(LFS_TYPE_CRC, 0x1ff,
  482. noff - (commit->off+sizeof(uint32_t)));
  483. // write out crc
  484. //printf("tag w %#010x (%x:%x %03x %03x %03x)\n", tag, commit->block, commit->off+sizeof(tag), lfs_tag_type(tag), lfs_tag_id(tag), lfs_tag_size(tag));
  485. uint32_t footer[2];
  486. footer[0] = lfs_tole32(tag ^ commit->ptag);
  487. lfs_crc(&commit->crc, &footer[0], sizeof(footer[0]));
  488. footer[1] = lfs_tole32(commit->crc);
  489. err = lfs_bd_prog(lfs, commit->block, commit->off,
  490. footer, sizeof(footer));
  491. if (err) {
  492. return err;
  493. }
  494. commit->off += sizeof(tag)+lfs_tag_size(tag);
  495. commit->ptag = tag;
  496. // flush buffers
  497. err = lfs_bd_sync(lfs);
  498. if (err) {
  499. return err;
  500. }
  501. // successful commit, check checksum to make sure
  502. uint32_t crc = 0xffffffff;
  503. err = lfs_bd_crc(lfs, commit->block, commit->begin,
  504. commit->off-lfs_tag_size(tag) - commit->begin, &crc);
  505. if (err) {
  506. return err;
  507. }
  508. if (crc != commit->crc) {
  509. return LFS_ERR_CORRUPT;
  510. }
  511. return 0;
  512. }
  513. // committer for regions
  514. static int lfs_commit_regions(lfs_t *lfs, void *p, struct lfs_commit *commit) {
  515. for (lfs_entrylist_t *regions = p; regions; regions = regions->next) {
  516. int err = lfs_commit_commit(lfs, commit, regions->e);
  517. if (err) {
  518. return err;
  519. }
  520. }
  521. return 0;
  522. }
  523. static int lfs_commit_list(lfs_t *lfs, struct lfs_commit *commit,
  524. lfs_entrylist_t *list) {
  525. for (; list; list = list->next) {
  526. int err = lfs_commit_commit(lfs, commit, list->e);
  527. if (err) {
  528. return err;
  529. }
  530. }
  531. return 0;
  532. }
  533. // committer for moves
  534. // TODO rename?
  535. struct lfs_commit_move {
  536. lfs_dir_t *dir;
  537. struct {
  538. uint16_t from;
  539. uint16_t to;
  540. } id;
  541. struct lfs_commit *commit;
  542. };
  543. // TODO redeclare
  544. static int lfs_dir_traverse(lfs_t *lfs, lfs_dir_t *dir,
  545. int (*cb)(lfs_t *lfs, void *data, lfs_entry_t entry),
  546. void *data);
  547. static int lfs_dir_get(lfs_t *lfs, lfs_dir_t *dir,
  548. uint32_t mask, lfs_entry_t *entry);
  549. static int lfs_commit_movescan(lfs_t *lfs, void *p, lfs_entry_t entry) {
  550. struct lfs_commit_move *move = p;
  551. if (lfs_tag_type(entry.tag) == LFS_TYPE_DELETE &&
  552. lfs_tag_id(entry.tag) <= move->id.from) {
  553. // something was deleted, we need to move around it
  554. move->id.from += 1;
  555. return 0;
  556. }
  557. if (lfs_tag_type(entry.tag) == LFS_TYPE_MOVE) {
  558. // TODO need this?
  559. // ignore moves
  560. return 0;
  561. }
  562. if (lfs_tag_id(entry.tag) != move->id.from) {
  563. // ignore non-matching ids
  564. return 0;
  565. }
  566. // check if type has already been committed
  567. int err = lfs_dir_get(lfs,
  568. &(lfs_dir_t){
  569. .pair[0]=move->commit->block,
  570. .off=move->commit->off,
  571. .etag=move->commit->ptag,
  572. .stop_at_commit=true},
  573. lfs_tag_type(entry.tag) & 0x100 ? 0x7ffff000 : 0x7c1ff000,
  574. &(lfs_entry_t){
  575. lfs_mktag(lfs_tag_type(entry.tag), move->id.to, 0)});
  576. if (err && err != LFS_ERR_NOENT) {
  577. return err;
  578. }
  579. if (err != LFS_ERR_NOENT) {
  580. // already committed
  581. return 0;
  582. }
  583. // update id and commit, as we are currently unique
  584. entry.tag = lfs_mktag(0, move->id.to, 0) | (entry.tag & 0xffe00fff);
  585. return lfs_commit_commit(lfs, move->commit, entry);
  586. }
  587. // TODO change this to be special RAM-side type in linked list of commits?
  588. static int lfs_commit_move(lfs_t *lfs, void *p, struct lfs_commit *commit) {
  589. struct lfs_commit_move *move = p;
  590. move->commit = commit;
  591. if (move->id.to < commit->filter.begin ||
  592. move->id.to >= commit->filter.end) {
  593. // skip if not in filter
  594. return 0;
  595. }
  596. int err = lfs_dir_traverse(lfs, move->dir, lfs_commit_movescan, move);
  597. if (err < 0) {
  598. return err;
  599. }
  600. return 0;
  601. }
  602. static int lfs_commit_move_(lfs_t *lfs, struct lfs_commit *commit,
  603. lfs_entry_t entry) {
  604. struct lfs_commit_move move = {
  605. .dir = entry.u.dir,
  606. .id.to = lfs_tag_id(entry.tag),
  607. .id.from = lfs_tag_size(entry.tag),
  608. .commit = commit,
  609. };
  610. int err = lfs_dir_traverse(lfs, entry.u.dir, lfs_commit_movescan, &move);
  611. if (err) {
  612. return err;
  613. }
  614. return 0;
  615. }
  616. static int lfs_dir_alloc(lfs_t *lfs, lfs_dir_t *dir,
  617. bool split, const lfs_block_t tail[2]) {
  618. // allocate pair of dir blocks (backwards, so we write to block 1 first)
  619. for (int i = 0; i < 2; i++) {
  620. int err = lfs_alloc(lfs, &dir->pair[(i+1)%2]);
  621. if (err) {
  622. return err;
  623. }
  624. }
  625. // rather than clobbering one of the blocks we just pretend
  626. // the revision may be valid
  627. int err = lfs_bd_read(lfs, dir->pair[0], 0, &dir->rev, 4);
  628. dir->rev = lfs_fromle32(dir->rev);
  629. if (err) {
  630. return err;
  631. }
  632. // set defaults
  633. dir->off = sizeof(dir->rev);
  634. dir->etag = 0;
  635. dir->count = 0;
  636. dir->tail[0] = tail[0];
  637. dir->tail[1] = tail[1];
  638. dir->erased = false;
  639. dir->split = split;
  640. // don't write out yet, let caller take care of that
  641. return 0;
  642. }
  643. static int lfs_dir_fetchwith(lfs_t *lfs,
  644. lfs_dir_t *dir, const lfs_block_t pair[2],
  645. int (*cb)(lfs_t *lfs, void *data, lfs_entry_t entry), void *data) {
  646. dir->pair[0] = pair[0];
  647. dir->pair[1] = pair[1];
  648. dir->stop_at_commit = false;
  649. // find the block with the most recent revision
  650. uint32_t rev[2];
  651. for (int i = 0; i < 2; i++) {
  652. int err = lfs_bd_read(lfs, dir->pair[i], 0, &rev[i], sizeof(rev[i]));
  653. rev[i] = lfs_fromle32(rev[i]);
  654. if (err) {
  655. return err;
  656. }
  657. }
  658. if (lfs_scmp(rev[1], rev[0]) > 0) {
  659. lfs_pairswap(dir->pair);
  660. lfs_pairswap(rev);
  661. }
  662. // load blocks and check crc
  663. for (int i = 0; i < 2; i++) {
  664. lfs_off_t off = sizeof(dir->rev);
  665. lfs_tag_t ptag = 0;
  666. uint32_t crc = 0xffffffff;
  667. dir->tail[0] = 0xffffffff;
  668. dir->tail[1] = 0xffffffff;
  669. dir->count = 0;
  670. dir->split = false;
  671. dir->moveid = -1;
  672. dir->rev = lfs_tole32(rev[0]);
  673. lfs_crc(&crc, &dir->rev, sizeof(dir->rev));
  674. dir->rev = lfs_fromle32(dir->rev);
  675. while (true) {
  676. // extract next tag
  677. lfs_tag_t tag;
  678. int err = lfs_bd_read(lfs, dir->pair[0], off, &tag, sizeof(tag));
  679. if (err) {
  680. return err;
  681. }
  682. lfs_crc(&crc, &tag, sizeof(tag));
  683. tag = lfs_fromle32(tag) ^ ptag;
  684. // next commit not yet programmed
  685. if (lfs_tag_type(ptag) == LFS_TYPE_CRC && !lfs_tag_valid(tag)) {
  686. dir->erased = true;
  687. return 0;
  688. }
  689. // check we're in valid range
  690. if (off + sizeof(tag)+lfs_tag_size(tag) > lfs->cfg->block_size) {
  691. break;
  692. }
  693. //printf("tag r %#010x (%x:%x %03x %03x %03x)\n", tag, dir->pair[0], off+sizeof(tag), lfs_tag_type(tag), lfs_tag_id(tag), lfs_tag_size(tag));
  694. if (lfs_tag_type(tag) == LFS_TYPE_CRC) {
  695. // check the crc entry
  696. uint32_t dcrc;
  697. int err = lfs_bd_read(lfs, dir->pair[0],
  698. off+sizeof(tag), &dcrc, sizeof(dcrc));
  699. if (err) {
  700. return err;
  701. }
  702. if (crc != lfs_fromle32(dcrc)) {
  703. if (off == sizeof(dir->rev)) {
  704. // try other block
  705. break;
  706. } else {
  707. // consider what we have good enough
  708. dir->erased = false;
  709. return 0;
  710. }
  711. }
  712. dir->off = off + sizeof(tag)+lfs_tag_size(tag);
  713. dir->etag = tag;
  714. crc = 0xffffffff;
  715. } else {
  716. err = lfs_bd_crc(lfs, dir->pair[0],
  717. off+sizeof(tag), lfs_tag_size(tag), &crc);
  718. if (err) {
  719. return err;
  720. }
  721. if (lfs_tag_type(tag) == LFS_TYPE_SOFTTAIL ||
  722. lfs_tag_type(tag) == LFS_TYPE_HARDTAIL) {
  723. dir->split = lfs_tag_type(tag) == LFS_TYPE_HARDTAIL;
  724. err = lfs_bd_read(lfs, dir->pair[0], off+sizeof(tag),
  725. dir->tail, sizeof(dir->tail));
  726. if (err) {
  727. return err;
  728. }
  729. } else if (lfs_tag_type(tag) == LFS_TYPE_MOVE) {
  730. // TODO handle moves correctly?
  731. dir->moveid = lfs_tag_id(tag);
  732. } else {
  733. if (lfs_tag_id(tag) < 0x1ff &&
  734. lfs_tag_id(tag) >= dir->count) {
  735. dir->count = lfs_tag_id(tag)+1;
  736. }
  737. if (lfs_tag_type(tag) == LFS_TYPE_DELETE) {
  738. dir->count -= 1;
  739. if (dir->moveid != -1) {
  740. //printf("RENAME DEL %d (%d)\n", lfs_tag_id(tag), dir->moveid);
  741. }
  742. if (lfs_tag_id(tag) == dir->moveid) {
  743. dir->moveid = -1;
  744. } else if (lfs_tag_id(tag) < dir->moveid) {
  745. dir->moveid -= 1;
  746. }
  747. }
  748. if (cb) {
  749. err = cb(lfs, data, (lfs_entry_t){
  750. (tag | 0x80000000),
  751. .u.d.block=dir->pair[0],
  752. .u.d.off=off+sizeof(tag)});
  753. if (err) {
  754. return err;
  755. }
  756. }
  757. }
  758. }
  759. ptag = tag;
  760. off += sizeof(tag)+lfs_tag_size(tag);
  761. }
  762. // failed, try the other crc?
  763. lfs_pairswap(dir->pair);
  764. lfs_pairswap(rev);
  765. }
  766. LFS_ERROR("Corrupted dir pair at %d %d", dir->pair[0], dir->pair[1]);
  767. return LFS_ERR_CORRUPT;
  768. }
  769. static int lfs_dir_fetch(lfs_t *lfs,
  770. lfs_dir_t *dir, const lfs_block_t pair[2]) {
  771. return lfs_dir_fetchwith(lfs, dir, pair, NULL, NULL);
  772. }
  773. static int lfs_dir_traverse(lfs_t *lfs, lfs_dir_t *dir,
  774. int (*cb)(lfs_t *lfs, void *data, lfs_entry_t entry), void *data) {
  775. // iterate over dir block backwards (for faster lookups)
  776. lfs_block_t block = dir->pair[0];
  777. lfs_off_t off = dir->off;
  778. lfs_tag_t tag = dir->etag;
  779. while (off != sizeof(uint32_t)) {
  780. // TODO rm me
  781. //printf("tag r %#010x (%x:%x %03x %03x %03x)\n", tag, block, off-lfs_tag_size(tag), lfs_tag_type(tag), lfs_tag_id(tag), lfs_tag_size(tag));
  782. // TODO hmm
  783. if (dir->stop_at_commit && lfs_tag_type(tag) == LFS_TYPE_CRC) {
  784. break;
  785. }
  786. int err = cb(lfs, data, (lfs_entry_t){
  787. (0x80000000 | tag),
  788. .u.d.block=block,
  789. .u.d.off=off-lfs_tag_size(tag)});
  790. if (err) {
  791. return err;
  792. }
  793. LFS_ASSERT(off > sizeof(tag)+lfs_tag_size(tag));
  794. off -= sizeof(tag)+lfs_tag_size(tag);
  795. lfs_tag_t ntag;
  796. err = lfs_bd_read(lfs, block, off, &ntag, sizeof(ntag));
  797. if (err) {
  798. return err;
  799. }
  800. tag ^= lfs_fromle32(ntag);
  801. }
  802. return 0;
  803. }
  804. //struct lfs_dir_commitmove {
  805. // // traversal things
  806. // lfs_dir_t *dir;
  807. // int (*cb)(lfs_t *lfs, void *data, struct lfs_commit *commit);
  808. // void *data;
  809. //
  810. // // ids to iterate through
  811. // uint16_t begin;
  812. // uint16_t end;
  813. // uint16_t ack;
  814. //};
  815. //
  816. //static int lfs_dir_commitmove_commit(lfs_t *lfs, void *p,
  817. // lfs_entry_t entry) {
  818. // return lfs_commit_commit(lfs, p, entry);
  819. //}
  820. //
  821. //int lfs_dir_commitmove(lfs_t *lfs, void *p, struct lfs_commit *commit) {
  822. // struct lfs_dir_commitmove *move = p;
  823. // for (int i = move->begin; i < move->end; i++) {
  824. // // tell the committer to check for duplicates
  825. // uint16_t old = commit->compact.id;
  826. // if (commit->compact.id < 0) {
  827. // commit->compact.id = i;
  828. // }
  829. //
  830. // // commit pending commits
  831. // int err = move->cb(lfs, move->data, commit);
  832. // if (err) {
  833. // commit->compact.id = old;
  834. // return err;
  835. // }
  836. //
  837. // // iterate over on-disk regions
  838. // err = lfs_dir_traverse(lfs, move->dir,
  839. // lfs_dir_commitmove_commit, commit);
  840. // if (err) {
  841. // commit->compact.id = old;
  842. // return err;
  843. // }
  844. //
  845. // move->ack = i;
  846. // commit->compact.id = old;
  847. // }
  848. //
  849. // return 0;
  850. //}
  851. static int lfs_dir_compact(lfs_t *lfs, lfs_dir_t *dir,
  852. int (*cb)(lfs_t *lfs, void *data, struct lfs_commit *commit),
  853. void *data, lfs_dir_t *source, uint16_t begin, uint16_t end) {
  854. // save some state in case block is bad
  855. const lfs_block_t oldpair[2] = {dir->pair[1], dir->pair[0]};
  856. bool relocated = false;
  857. // increment revision count
  858. dir->rev += 1;
  859. while (true) {
  860. // last complete id
  861. int16_t ack = -1;
  862. dir->count = end - begin;
  863. if (true) {
  864. // erase block to write to
  865. int err = lfs_bd_erase(lfs, dir->pair[1]);
  866. if (err) {
  867. if (err == LFS_ERR_CORRUPT) {
  868. goto relocate;
  869. }
  870. return err;
  871. }
  872. // write out header
  873. uint32_t crc = 0xffffffff;
  874. uint32_t rev = lfs_tole32(dir->rev);
  875. lfs_crc(&crc, &rev, sizeof(rev));
  876. err = lfs_bd_prog(lfs, dir->pair[1], 0, &rev, sizeof(rev));
  877. if (err) {
  878. if (err == LFS_ERR_CORRUPT) {
  879. goto relocate;
  880. }
  881. return err;
  882. }
  883. // setup compaction
  884. struct lfs_commit commit = {
  885. .block = dir->pair[1],
  886. .off = sizeof(dir->rev),
  887. // space is complicated, we need room for tail, crc,
  888. // and we keep cap at around half a block
  889. .begin = 0,
  890. .end = lfs_min(
  891. lfs_alignup(lfs->cfg->block_size / 2,
  892. lfs->cfg->prog_size),
  893. lfs->cfg->block_size - 5*sizeof(uint32_t)),
  894. .crc = crc,
  895. .ptag = 0,
  896. // filter out ids
  897. .filter.begin = begin,
  898. .filter.end = end,
  899. };
  900. // commit regions which can't fend for themselves
  901. err = cb(lfs, data, &commit);
  902. if (err) {
  903. if (err == LFS_ERR_NOSPC) {
  904. goto split;
  905. } else if (err == LFS_ERR_CORRUPT) {
  906. goto relocate;
  907. }
  908. return err;
  909. }
  910. // move over other commits, leaving it up to lfs_commit_move to
  911. // filter out duplicates, and the commit filtering to reassign ids
  912. for (uint16_t id = begin; id < end; id++) {
  913. err = lfs_commit_move(lfs,
  914. &(struct lfs_commit_move){.dir=source, .id={id, id}},
  915. &commit);
  916. if (err) {
  917. if (err == LFS_ERR_NOSPC) {
  918. goto split;
  919. } else if (err == LFS_ERR_CORRUPT) {
  920. goto relocate;
  921. }
  922. return err;
  923. }
  924. ack = id;
  925. }
  926. commit.end = lfs->cfg->block_size - 2*sizeof(uint32_t);
  927. if (!lfs_pairisnull(dir->tail)) {
  928. // TODO le32
  929. err = lfs_commit_commit(lfs, &commit, (lfs_entry_t){
  930. lfs_mktag(LFS_TYPE_SOFTTAIL + dir->split*0x10,
  931. 0x1ff, sizeof(dir->tail)),
  932. .u.buffer=dir->tail});
  933. if (err) {
  934. if (err == LFS_ERR_CORRUPT) {
  935. goto relocate;
  936. }
  937. return err;
  938. }
  939. }
  940. err = lfs_commit_crc(lfs, &commit);
  941. if (err) {
  942. if (err == LFS_ERR_CORRUPT) {
  943. goto relocate;
  944. }
  945. return err;
  946. }
  947. // successful compaction, swap dir pair to indicate most recent
  948. lfs_pairswap(dir->pair);
  949. dir->off = commit.off;
  950. dir->etag = commit.ptag;
  951. dir->erased = true;
  952. }
  953. break;
  954. split:
  955. // commit no longer fits, need to split dir,
  956. // drop caches and create tail
  957. lfs->pcache.block = 0xffffffff;
  958. lfs_dir_t tail;
  959. int err = lfs_dir_alloc(lfs, &tail, dir->split, dir->tail);
  960. if (err) {
  961. return err;
  962. }
  963. err = lfs_dir_compact(lfs, &tail, cb, data, dir, ack+1, end);
  964. if (err) {
  965. return err;
  966. }
  967. end = ack+1;
  968. dir->tail[0] = tail.pair[0];
  969. dir->tail[1] = tail.pair[1];
  970. dir->split = true;
  971. continue;
  972. relocate:
  973. //commit was corrupted
  974. LFS_DEBUG("Bad block at %d", dir->pair[1]);
  975. // drop caches and prepare to relocate block
  976. relocated = true;
  977. lfs->pcache.block = 0xffffffff;
  978. // can't relocate superblock, filesystem is now frozen
  979. if (lfs_paircmp(oldpair, (const lfs_block_t[2]){0, 1}) == 0) {
  980. LFS_WARN("Superblock %d has become unwritable", oldpair[1]);
  981. return LFS_ERR_CORRUPT;
  982. }
  983. // relocate half of pair
  984. err = lfs_alloc(lfs, &dir->pair[1]);
  985. if (err) {
  986. return err;
  987. }
  988. continue;
  989. }
  990. if (relocated) {
  991. // update references if we relocated
  992. LFS_DEBUG("Relocating %d %d to %d %d",
  993. oldpair[0], oldpair[1], dir->pair[0], dir->pair[1]);
  994. int err = lfs_relocate(lfs, oldpair, dir->pair);
  995. if (err) {
  996. return err;
  997. }
  998. }
  999. // shift over any directories that are affected
  1000. for (lfs_dir_t *d = lfs->dirs; d; d = d->next) {
  1001. if (lfs_paircmp(d->pair, dir->pair) == 0) {
  1002. d->pair[0] = dir->pair[0];
  1003. d->pair[1] = dir->pair[1];
  1004. }
  1005. }
  1006. return 0;
  1007. }
  1008. static int lfs_dir_compact_(lfs_t *lfs, lfs_dir_t *dir, lfs_entrylist_t *list,
  1009. lfs_dir_t *source, uint16_t begin, uint16_t end) {
  1010. // save some state in case block is bad
  1011. const lfs_block_t oldpair[2] = {dir->pair[1], dir->pair[0]};
  1012. bool relocated = false;
  1013. // increment revision count
  1014. dir->rev += 1;
  1015. while (true) {
  1016. // last complete id
  1017. int16_t ack = -1;
  1018. dir->count = end - begin;
  1019. if (true) {
  1020. // erase block to write to
  1021. int err = lfs_bd_erase(lfs, dir->pair[1]);
  1022. if (err) {
  1023. if (err == LFS_ERR_CORRUPT) {
  1024. goto relocate;
  1025. }
  1026. return err;
  1027. }
  1028. // write out header
  1029. uint32_t crc = 0xffffffff;
  1030. uint32_t rev = lfs_tole32(dir->rev);
  1031. lfs_crc(&crc, &rev, sizeof(rev));
  1032. err = lfs_bd_prog(lfs, dir->pair[1], 0, &rev, sizeof(rev));
  1033. if (err) {
  1034. if (err == LFS_ERR_CORRUPT) {
  1035. goto relocate;
  1036. }
  1037. return err;
  1038. }
  1039. // setup compaction
  1040. struct lfs_commit commit = {
  1041. .block = dir->pair[1],
  1042. .off = sizeof(dir->rev),
  1043. // space is complicated, we need room for tail, crc,
  1044. // and we keep cap at around half a block
  1045. .begin = 0,
  1046. .end = lfs_min(
  1047. lfs_alignup(lfs->cfg->block_size / 2,
  1048. lfs->cfg->prog_size),
  1049. lfs->cfg->block_size - 5*sizeof(uint32_t)),
  1050. .crc = crc,
  1051. .ptag = 0,
  1052. // filter out ids
  1053. .filter.begin = begin,
  1054. .filter.end = end,
  1055. };
  1056. // commit regions which can't fend for themselves
  1057. err = lfs_commit_list(lfs, &commit, list);
  1058. if (err) {
  1059. if (err == LFS_ERR_NOSPC) {
  1060. goto split;
  1061. } else if (err == LFS_ERR_CORRUPT) {
  1062. goto relocate;
  1063. }
  1064. return err;
  1065. }
  1066. // move over other commits, leaving it up to lfs_commit_move to
  1067. // filter out duplicates, and the commit filtering to reassign ids
  1068. for (uint16_t id = begin; id < end; id++) {
  1069. err = lfs_commit_commit(lfs, &commit, (lfs_entry_t){
  1070. lfs_mktag(LFS_FROM_MOVE, id, id), .u.dir=source});
  1071. if (err) {
  1072. if (err == LFS_ERR_NOSPC) {
  1073. goto split;
  1074. } else if (err == LFS_ERR_CORRUPT) {
  1075. goto relocate;
  1076. }
  1077. return err;
  1078. }
  1079. ack = id;
  1080. }
  1081. commit.end = lfs->cfg->block_size - 2*sizeof(uint32_t);
  1082. if (!lfs_pairisnull(dir->tail)) {
  1083. // TODO le32
  1084. err = lfs_commit_commit(lfs, &commit, (lfs_entry_t){
  1085. lfs_mktag(LFS_TYPE_SOFTTAIL + dir->split*0x10,
  1086. 0x1ff, sizeof(dir->tail)),
  1087. .u.buffer=dir->tail});
  1088. if (err) {
  1089. if (err == LFS_ERR_CORRUPT) {
  1090. goto relocate;
  1091. }
  1092. return err;
  1093. }
  1094. }
  1095. err = lfs_commit_crc(lfs, &commit);
  1096. if (err) {
  1097. if (err == LFS_ERR_CORRUPT) {
  1098. goto relocate;
  1099. }
  1100. return err;
  1101. }
  1102. // successful compaction, swap dir pair to indicate most recent
  1103. lfs_pairswap(dir->pair);
  1104. dir->off = commit.off;
  1105. dir->etag = commit.ptag;
  1106. dir->erased = true;
  1107. }
  1108. break;
  1109. split:
  1110. // commit no longer fits, need to split dir,
  1111. // drop caches and create tail
  1112. lfs->pcache.block = 0xffffffff;
  1113. lfs_dir_t tail;
  1114. int err = lfs_dir_alloc(lfs, &tail, dir->split, dir->tail);
  1115. if (err) {
  1116. return err;
  1117. }
  1118. err = lfs_dir_compact_(lfs, &tail, list, dir, ack+1, end);
  1119. if (err) {
  1120. return err;
  1121. }
  1122. end = ack+1;
  1123. dir->tail[0] = tail.pair[0];
  1124. dir->tail[1] = tail.pair[1];
  1125. dir->split = true;
  1126. continue;
  1127. relocate:
  1128. //commit was corrupted
  1129. LFS_DEBUG("Bad block at %d", dir->pair[1]);
  1130. // drop caches and prepare to relocate block
  1131. relocated = true;
  1132. lfs->pcache.block = 0xffffffff;
  1133. // can't relocate superblock, filesystem is now frozen
  1134. if (lfs_paircmp(oldpair, (const lfs_block_t[2]){0, 1}) == 0) {
  1135. LFS_WARN("Superblock %d has become unwritable", oldpair[1]);
  1136. return LFS_ERR_CORRUPT;
  1137. }
  1138. // relocate half of pair
  1139. err = lfs_alloc(lfs, &dir->pair[1]);
  1140. if (err) {
  1141. return err;
  1142. }
  1143. continue;
  1144. }
  1145. if (relocated) {
  1146. // update references if we relocated
  1147. LFS_DEBUG("Relocating %d %d to %d %d",
  1148. oldpair[0], oldpair[1], dir->pair[0], dir->pair[1]);
  1149. int err = lfs_relocate(lfs, oldpair, dir->pair);
  1150. if (err) {
  1151. return err;
  1152. }
  1153. }
  1154. // shift over any directories that are affected
  1155. for (lfs_dir_t *d = lfs->dirs; d; d = d->next) {
  1156. if (lfs_paircmp(d->pair, dir->pair) == 0) {
  1157. d->pair[0] = dir->pair[0];
  1158. d->pair[1] = dir->pair[1];
  1159. }
  1160. }
  1161. return 0;
  1162. }
  1163. static int lfs_dir_commit_(lfs_t *lfs, lfs_dir_t *dir, lfs_entrylist_t *list) {
  1164. if (!dir->erased) {
  1165. // not erased, must compact
  1166. return lfs_dir_compact_(lfs, dir, list, dir, 0, dir->count);
  1167. }
  1168. struct lfs_commit commit = {
  1169. .block = dir->pair[0],
  1170. .begin = dir->off,
  1171. .off = dir->off,
  1172. .end = lfs->cfg->block_size - 2*sizeof(uint32_t),
  1173. .crc = 0xffffffff,
  1174. .ptag = dir->etag,
  1175. .filter.begin = 0,
  1176. .filter.end = 0x1ff,
  1177. };
  1178. int err = lfs_commit_list(lfs, &commit, list);
  1179. if (err) {
  1180. if (err == LFS_ERR_NOSPC || err == LFS_ERR_CORRUPT) {
  1181. lfs->pcache.block = 0xffffffff;
  1182. return lfs_dir_compact_(lfs, dir, list, dir, 0, dir->count);
  1183. }
  1184. return err;
  1185. }
  1186. err = lfs_commit_crc(lfs, &commit);
  1187. if (err) {
  1188. if (err == LFS_ERR_NOSPC || err == LFS_ERR_CORRUPT) {
  1189. lfs->pcache.block = 0xffffffff;
  1190. return lfs_dir_compact_(lfs, dir, list, dir, 0, dir->count);
  1191. }
  1192. return err;
  1193. }
  1194. // successful commit, lets update dir
  1195. dir->off = commit.off;
  1196. dir->etag = commit.ptag;
  1197. return 0;
  1198. }
  1199. static int lfs_dir_commitwith(lfs_t *lfs, lfs_dir_t *dir,
  1200. int (*cb)(lfs_t *lfs, void *data, struct lfs_commit *commit),
  1201. void *data) {
  1202. if (!dir->erased) {
  1203. // not erased, must compact
  1204. return lfs_dir_compact(lfs, dir, cb, data, dir, 0, dir->count);
  1205. }
  1206. struct lfs_commit commit = {
  1207. .block = dir->pair[0],
  1208. .begin = dir->off,
  1209. .off = dir->off,
  1210. .end = lfs->cfg->block_size - 2*sizeof(uint32_t),
  1211. .crc = 0xffffffff,
  1212. .ptag = dir->etag,
  1213. .filter.begin = 0,
  1214. .filter.end = 0x1ff,
  1215. };
  1216. int err = cb(lfs, data, &commit);
  1217. if (err) {
  1218. if (err == LFS_ERR_NOSPC || err == LFS_ERR_CORRUPT) {
  1219. lfs->pcache.block = 0xffffffff;
  1220. return lfs_dir_compact(lfs, dir, cb, data, dir, 0, dir->count);
  1221. }
  1222. return err;
  1223. }
  1224. err = lfs_commit_crc(lfs, &commit);
  1225. if (err) {
  1226. if (err == LFS_ERR_NOSPC || err == LFS_ERR_CORRUPT) {
  1227. lfs->pcache.block = 0xffffffff;
  1228. return lfs_dir_compact(lfs, dir, cb, data, dir, 0, dir->count);
  1229. }
  1230. return err;
  1231. }
  1232. // successful commit, lets update dir
  1233. dir->off = commit.off;
  1234. dir->etag = commit.ptag;
  1235. return 0;
  1236. }
  1237. static int lfs_dir_commit(lfs_t *lfs, lfs_dir_t *dir,
  1238. const lfs_entrylist_t *regions) {
  1239. return lfs_dir_commitwith(lfs, dir, lfs_commit_regions, (void*)regions);
  1240. }
  1241. static int lfs_dir_append(lfs_t *lfs, lfs_dir_t *dir, uint16_t *id) {
  1242. *id = dir->count;
  1243. dir->count += 1;
  1244. return 0;
  1245. }
  1246. static int lfs_dir_delete(lfs_t *lfs, lfs_dir_t *dir, uint16_t id) {
  1247. dir->count -= 1;
  1248. return lfs_dir_commit_(lfs, dir, &(lfs_entrylist_t){
  1249. {lfs_mktag(LFS_TYPE_DELETE, id, 0)}});
  1250. }
  1251. struct lfs_dir_getter {
  1252. uint32_t mask;
  1253. lfs_tag_t tag;
  1254. lfs_entry_t *entry;
  1255. };
  1256. static int lfs_dir_getter(lfs_t *lfs, void *p, lfs_entry_t entry) {
  1257. struct lfs_dir_getter *get = p;
  1258. if ((entry.tag & get->mask) == (get->tag & get->mask)) {
  1259. *get->entry = entry;
  1260. return true;
  1261. } else if (lfs_tag_type(entry.tag) == LFS_TYPE_DELETE) {
  1262. if (lfs_tag_id(entry.tag) <= lfs_tag_id(get->tag)) {
  1263. get->tag += lfs_mktag(0, 1, 0);
  1264. }
  1265. }
  1266. return false;
  1267. }
  1268. static int lfs_dir_get(lfs_t *lfs, lfs_dir_t *dir,
  1269. uint32_t mask, lfs_entry_t *entry) {
  1270. uint16_t id = lfs_tag_id(entry->tag);
  1271. int res = lfs_dir_traverse(lfs, dir, lfs_dir_getter,
  1272. &(struct lfs_dir_getter){mask, entry->tag, entry});
  1273. if (res < 0) {
  1274. return res;
  1275. }
  1276. if (!res) {
  1277. return LFS_ERR_NOENT;
  1278. }
  1279. // TODO hmm, stop at commit? maybe we need to handle this elsewhere?
  1280. // Should commit get be its own thing? commit traverse?
  1281. if (id == dir->moveid && !dir->stop_at_commit) {
  1282. int moved = lfs_moved(lfs, dir, dir->moveid);
  1283. if (moved < 0) {
  1284. return moved;
  1285. }
  1286. if (moved) {
  1287. return LFS_ERR_NOENT;
  1288. }
  1289. }
  1290. entry->tag = lfs_mktag(0, id, 0) | (entry->tag & 0xffe00fff);
  1291. return 0;
  1292. }
  1293. static int lfs_dir_getbuffer(lfs_t *lfs, lfs_dir_t *dir,
  1294. uint32_t mask, lfs_entry_t *entry) {
  1295. void *buffer = entry->u.buffer;
  1296. lfs_size_t size = lfs_tag_size(entry->tag);
  1297. int err = lfs_dir_get(lfs, dir, mask, entry);
  1298. if (err) {
  1299. return err;
  1300. }
  1301. lfs_size_t diff = lfs_min(size, lfs_tag_size(entry->tag));
  1302. memset((uint8_t*)buffer + diff, 0, size - diff);
  1303. err = lfs_bd_read(lfs, entry->u.d.block, entry->u.d.off, buffer, diff);
  1304. if (err) {
  1305. return err;
  1306. }
  1307. if (lfs_tag_size(entry->tag) > size) {
  1308. return LFS_ERR_RANGE;
  1309. }
  1310. return 0;
  1311. }
  1312. static int lfs_dir_getentry(lfs_t *lfs, lfs_dir_t *dir,
  1313. uint32_t mask, lfs_tag_t tag, lfs_entry_t *entry) {
  1314. entry->tag = tag | sizeof(entry->u);
  1315. entry->u.buffer = &entry->u;
  1316. int err = lfs_dir_getbuffer(lfs, dir, mask, entry);
  1317. if (err && err != LFS_ERR_RANGE) {
  1318. return err;
  1319. }
  1320. return 0;
  1321. }
  1322. static int lfs_dir_getinfo(lfs_t *lfs, lfs_dir_t *dir,
  1323. int16_t id, struct lfs_info *info) {
  1324. if (id < 0) {
  1325. // special case for root
  1326. strcpy(info->name, "/");
  1327. info->type = LFS_TYPE_DIR;
  1328. return 0;
  1329. }
  1330. lfs_entry_t entry;
  1331. int err = lfs_dir_getentry(lfs, dir, 0x701ff000,
  1332. lfs_mktag(LFS_TYPE_REG, id, 0), &entry);
  1333. if (err) {
  1334. return err;
  1335. }
  1336. info->type = lfs_tag_subtype(entry.tag);
  1337. if (lfs_tag_type(entry.tag) == (LFS_TYPE_REG | LFS_STRUCT_CTZ)) {
  1338. info->size = entry.u.ctz.size;
  1339. } else if (lfs_tag_type(entry.tag) == (LFS_TYPE_REG | LFS_STRUCT_INLINE)) {
  1340. info->size = lfs_tag_size(entry.tag);
  1341. }
  1342. err = lfs_dir_getbuffer(lfs, dir, 0x7ffff000, &(lfs_entry_t){
  1343. lfs_mktag(LFS_TYPE_NAME, id, lfs->name_size+1),
  1344. .u.buffer=info->name});
  1345. if (err) {
  1346. return err;
  1347. }
  1348. return 0;
  1349. }
  1350. struct lfs_dir_finder {
  1351. const char *name;
  1352. uint16_t len;
  1353. int16_t id;
  1354. };
  1355. static int lfs_dir_finder(lfs_t *lfs, void *p, lfs_entry_t entry) {
  1356. struct lfs_dir_finder *find = p;
  1357. if (lfs_tag_type(entry.tag) == LFS_TYPE_NAME &&
  1358. lfs_tag_size(entry.tag) == find->len) {
  1359. int res = lfs_bd_cmp(lfs, entry.u.d.block, entry.u.d.off,
  1360. find->name, find->len);
  1361. if (res < 0) {
  1362. return res;
  1363. }
  1364. if (res) {
  1365. // found a match
  1366. find->id = lfs_tag_id(entry.tag);
  1367. }
  1368. } else if (lfs_tag_type(entry.tag) == LFS_TYPE_DELETE) {
  1369. if (lfs_tag_id(entry.tag) == find->id) {
  1370. find->id = -1;
  1371. } else if (lfs_tag_id(entry.tag) < find->id) {
  1372. find->id -= 1;
  1373. }
  1374. }
  1375. return 0;
  1376. }
  1377. // TODO drop others, make this only return id, also make get take in only entry to populate (with embedded tag)
  1378. static int lfs_dir_find(lfs_t *lfs, lfs_dir_t *dir,
  1379. const char **path, int16_t *id) {
  1380. lfs_entry_t entry = {
  1381. .u.pair[0] = lfs->root[0],
  1382. .u.pair[1] = lfs->root[1],
  1383. };
  1384. struct lfs_dir_finder find = {
  1385. .name = *path,
  1386. };
  1387. while (true) {
  1388. nextname:
  1389. // skip slashes
  1390. find.name += strspn(find.name, "/");
  1391. find.len = strcspn(find.name, "/");
  1392. // special case for root dir
  1393. if (find.name[0] == '\0') {
  1394. // TODO set up root?
  1395. *id = -1;
  1396. return 0;
  1397. }
  1398. // skip '.' and root '..'
  1399. if ((find.len == 1 && memcmp(find.name, ".", 1) == 0) ||
  1400. (find.len == 2 && memcmp(find.name, "..", 2) == 0)) {
  1401. find.name += find.len;
  1402. goto nextname;
  1403. }
  1404. // skip if matched by '..' in name
  1405. const char *suffix = find.name + find.len;
  1406. lfs_size_t sufflen;
  1407. int depth = 1;
  1408. while (true) {
  1409. suffix += strspn(suffix, "/");
  1410. sufflen = strcspn(suffix, "/");
  1411. if (sufflen == 0) {
  1412. break;
  1413. }
  1414. if (sufflen == 2 && memcmp(suffix, "..", 2) == 0) {
  1415. depth -= 1;
  1416. if (depth == 0) {
  1417. find.name = suffix + sufflen;
  1418. goto nextname;
  1419. }
  1420. } else {
  1421. depth += 1;
  1422. }
  1423. suffix += sufflen;
  1424. }
  1425. // update what we've found
  1426. *path = find.name;
  1427. // find path
  1428. while (true) {
  1429. printf("checking %d %d for %s\n", entry.u.pair[0], entry.u.pair[1], *path);
  1430. find.id = -1;
  1431. int err = lfs_dir_fetchwith(lfs, dir, entry.u.pair,
  1432. lfs_dir_finder, &find);
  1433. if (err) {
  1434. return err;
  1435. }
  1436. if (find.id >= 0) {
  1437. // found it
  1438. break;
  1439. }
  1440. if (!dir->split) {
  1441. return LFS_ERR_NOENT;
  1442. }
  1443. entry.u.pair[0] = dir->tail[0];
  1444. entry.u.pair[1] = dir->tail[1];
  1445. }
  1446. if (find.id == dir->moveid) {
  1447. int moved = lfs_moved(lfs, dir, dir->moveid);
  1448. if (moved < 0) {
  1449. return moved;
  1450. }
  1451. if (moved) {
  1452. return LFS_ERR_NOENT;
  1453. }
  1454. }
  1455. *id = find.id;
  1456. find.name += find.len;
  1457. find.name += strspn(find.name, "/");
  1458. if (find.name[0] == '\0') {
  1459. return 0;
  1460. }
  1461. // TODO optimize grab for inline files and like?
  1462. // TODO would this mean more code?
  1463. // grab the entry data
  1464. int err = lfs_dir_getentry(lfs, dir, 0x701ff000,
  1465. lfs_mktag(LFS_TYPE_REG, find.id, 0), &entry);
  1466. if (err) {
  1467. return err;
  1468. }
  1469. // continue on if we hit a directory
  1470. // TODO update with what's on master?
  1471. if (lfs_tag_subtype(entry.tag) != LFS_TYPE_DIR) {
  1472. return LFS_ERR_NOTDIR;
  1473. }
  1474. }
  1475. }
  1476. //static int lfs_dir_findbuffer(lfs_t *lfs, lfs_dir_t *dir,
  1477. // const char **path, lfs_entry_t *entry) {
  1478. // void *buffer = entry->u.buffer;
  1479. // lfs_size_t size = lfs_tag_size(entry->tag);
  1480. // int err = lfs_dir_find(lfs, dir, path, entry);
  1481. // if (err) {
  1482. // return err;
  1483. // }
  1484. //
  1485. // lfs_size_t diff = lfs_min(size, lfs_tag_size(entry->tag));
  1486. // memset((uint8_t*)buffer + diff, 0, size - diff);
  1487. // // TODO hmm
  1488. // if (lfs_tag_valid(entry->tag)) {
  1489. // memcpy(buffer, entry->u.buffer, diff);
  1490. // } else {
  1491. // err = lfs_bd_read(lfs, entry->u.d.block, entry->u.d.off, buffer, diff);
  1492. // if (err) {
  1493. // return err;
  1494. // }
  1495. // }
  1496. //
  1497. // if (lfs_tag_size(entry->tag) > size) {
  1498. // return LFS_ERR_RANGE;
  1499. // }
  1500. //
  1501. // return 0;
  1502. //}
  1503. //
  1504. //static int lfs_dir_findentry(lfs_t *lfs, lfs_dir_t *dir,
  1505. // const char **path, lfs_entry_t *entry) {
  1506. // entry->tag = sizeof(entry->u);
  1507. // entry->u.buffer = &entry->u;
  1508. // return lfs_dir_findbuffer(lfs, dir, path, entry);
  1509. //}
  1510. //////////////////////////////////////////////////////////
  1511. //static int lfs_dir_alloc(lfs_t *lfs, lfs_dir_t *dir) {
  1512. // // allocate pair of dir blocks
  1513. // for (int i = 0; i < 2; i++) {
  1514. // int err = lfs_alloc(lfs, &dir->pair[i]);
  1515. // if (err) {
  1516. // return err;
  1517. // }
  1518. // }
  1519. //
  1520. // // rather than clobbering one of the blocks we just pretend
  1521. // // the revision may be valid
  1522. // int err = lfs_bd_read(lfs, dir->pair[0], 0, &dir->d.rev, 4);
  1523. // dir->d.rev = lfs_fromle32(dir->d.rev);
  1524. // if (err) {
  1525. // return err;
  1526. // }
  1527. //
  1528. // // set defaults
  1529. // dir->d.rev += 1;
  1530. // dir->d.size = sizeof(dir->d)+4;
  1531. // dir->d.tail[0] = 0xffffffff;
  1532. // dir->d.tail[1] = 0xffffffff;
  1533. // dir->off = sizeof(dir->d);
  1534. //
  1535. // // don't write out yet, let caller take care of that
  1536. // return 0;
  1537. //}
  1538. //
  1539. //static int lfs_dir_fetch(lfs_t *lfs,
  1540. // lfs_dir_t *dir, const lfs_block_t pair[2]) {
  1541. // // copy out pair, otherwise may be aliasing dir
  1542. // const lfs_block_t tpair[2] = {pair[0], pair[1]};
  1543. // bool valid = false;
  1544. //
  1545. // // check both blocks for the most recent revision
  1546. // for (int i = 0; i < 2; i++) {
  1547. // struct lfs_disk_dir test;
  1548. // int err = lfs_bd_read(lfs, tpair[i], 0, &test, sizeof(test));
  1549. // lfs_dir_fromle32(&test);
  1550. // if (err) {
  1551. // return err;
  1552. // }
  1553. //
  1554. // if (valid && lfs_scmp(test.rev, dir->d.rev) < 0) {
  1555. // continue;
  1556. // }
  1557. //
  1558. // if ((0x7fffffff & test.size) < sizeof(test)+4 ||
  1559. // (0x7fffffff & test.size) > lfs->cfg->block_size) {
  1560. // continue;
  1561. // }
  1562. //
  1563. // uint32_t crc = 0xffffffff;
  1564. // lfs_dir_tole32(&test);
  1565. // lfs_crc(&crc, &test, sizeof(test));
  1566. // lfs_dir_fromle32(&test);
  1567. // err = lfs_bd_crc(lfs, tpair[i], sizeof(test),
  1568. // (0x7fffffff & test.size) - sizeof(test), &crc);
  1569. // if (err) {
  1570. // return err;
  1571. // }
  1572. //
  1573. // if (crc != 0) {
  1574. // continue;
  1575. // }
  1576. //
  1577. // valid = true;
  1578. //
  1579. // // setup dir in case it's valid
  1580. // dir->pair[0] = tpair[(i+0) % 2];
  1581. // dir->pair[1] = tpair[(i+1) % 2];
  1582. // dir->off = sizeof(dir->d);
  1583. // dir->d = test;
  1584. // }
  1585. //
  1586. // if (!valid) {
  1587. // LFS_ERROR("Corrupted dir pair at %d %d", tpair[0], tpair[1]);
  1588. // return LFS_ERR_CORRUPT;
  1589. // }
  1590. //
  1591. // return 0;
  1592. //}
  1593. //
  1594. //struct lfs_region {
  1595. // enum {
  1596. // LFS_FROM_MEM,
  1597. // LFS_FROM_REGION,
  1598. // LFS_FROM_ATTRS,
  1599. // } type;
  1600. //
  1601. // lfs_off_t oldoff;
  1602. // lfs_size_t oldsize;
  1603. // const void *buffer;
  1604. // lfs_size_t newsize;
  1605. //};
  1606. //
  1607. //struct lfs_region_attrs {
  1608. // const struct lfs_attr *attrs;
  1609. // int count;
  1610. //};
  1611. //
  1612. //struct lfs_region_region {
  1613. // lfs_block_t block;
  1614. // lfs_off_t off;
  1615. // struct lfs_region *regions;
  1616. // int count;
  1617. //};
  1618. //
  1619. //static int lfs_commit_region(lfs_t *lfs, uint32_t *crc,
  1620. // lfs_block_t oldblock, lfs_off_t oldoff,
  1621. // lfs_block_t newblock, lfs_off_t newoff,
  1622. // lfs_off_t regionoff, lfs_size_t regionsize,
  1623. // const struct lfs_region *regions, int count) {
  1624. // int i = 0;
  1625. // lfs_size_t newend = newoff + regionsize;
  1626. // while (newoff < newend) {
  1627. // // commit from different types of regions
  1628. // if (i < count && regions[i].oldoff == oldoff - regionoff) {
  1629. // switch (regions[i].type) {
  1630. // case LFS_FROM_MEM: {
  1631. // lfs_crc(crc, regions[i].buffer, regions[i].newsize);
  1632. // int err = lfs_bd_prog(lfs, newblock, newoff,
  1633. // regions[i].buffer, regions[i].newsize);
  1634. // if (err) {
  1635. // return err;
  1636. // }
  1637. // newoff += regions[i].newsize;
  1638. // oldoff += regions[i].oldsize;
  1639. // break;
  1640. // }
  1641. // case LFS_FROM_REGION: {
  1642. // const struct lfs_region_region *disk = regions[i].buffer;
  1643. // int err = lfs_commit_region(lfs, crc,
  1644. // disk->block, disk->off,
  1645. // newblock, newoff,
  1646. // disk->off, regions[i].newsize,
  1647. // disk->regions, disk->count);
  1648. // if (err) {
  1649. // return err;
  1650. // }
  1651. // newoff += regions[i].newsize;
  1652. // oldoff -= regions[i].oldsize;
  1653. // break;
  1654. // }
  1655. // case LFS_FROM_ATTRS: {
  1656. // const struct lfs_region_attrs *attrs = regions[i].buffer;
  1657. //
  1658. // // order doesn't matter, so we write new attrs first. this
  1659. // // is still O(n^2) but only O(n) disk access
  1660. // for (int j = 0; j < attrs->count; j++) {
  1661. // if (attrs->attrs[j].size == 0) {
  1662. // continue;
  1663. // }
  1664. //
  1665. // lfs_entry_attr_t attr;
  1666. // attr.d.type = attrs->attrs[j].type;
  1667. // attr.d.len = attrs->attrs[j].size;
  1668. //
  1669. // lfs_crc(crc, &attr.d, sizeof(attr.d));
  1670. // int err = lfs_bd_prog(lfs, newblock, newoff,
  1671. // &attr.d, sizeof(attr.d));
  1672. // if (err) {
  1673. // return err;
  1674. // }
  1675. //
  1676. // lfs_crc(crc,
  1677. // attrs->attrs[j].buffer, attrs->attrs[j].size);
  1678. // err = lfs_bd_prog(lfs, newblock, newoff+sizeof(attr.d),
  1679. // attrs->attrs[j].buffer, attrs->attrs[j].size);
  1680. // if (err) {
  1681. // return err;
  1682. // }
  1683. //
  1684. // newoff += 2+attrs->attrs[j].size;
  1685. // }
  1686. //
  1687. // // copy over attributes without updates
  1688. // lfs_off_t oldend = oldoff + regions[i].oldsize;
  1689. // while (oldoff < oldend) {
  1690. // lfs_entry_attr_t attr;
  1691. // int err = lfs_bd_read(lfs, oldblock, oldoff,
  1692. // &attr.d, sizeof(attr.d));
  1693. // if (err) {
  1694. // return err;
  1695. // }
  1696. //
  1697. // bool updating = false;
  1698. // for (int j = 0; j < attrs->count; j++) {
  1699. // if (attr.d.type == attrs->attrs[j].type) {
  1700. // updating = true;
  1701. // }
  1702. // }
  1703. //
  1704. // if (!updating) {
  1705. // err = lfs_commit_region(lfs, crc,
  1706. // oldblock, oldoff,
  1707. // newblock, newoff,
  1708. // 0, 2+attr.d.len,
  1709. // NULL, 0);
  1710. // if (err) {
  1711. // return err;
  1712. // }
  1713. //
  1714. // newoff += 2+attr.d.len;
  1715. // }
  1716. //
  1717. // oldoff += 2+attr.d.len;
  1718. // }
  1719. //
  1720. // break;
  1721. // }
  1722. // }
  1723. //
  1724. // i += 1;
  1725. // } else {
  1726. // // copy data from old block if not covered by entry
  1727. // uint8_t data;
  1728. // int err = lfs_bd_read(lfs, oldblock, oldoff, &data, 1);
  1729. // if (err) {
  1730. // return err;
  1731. // }
  1732. //
  1733. // lfs_crc(crc, &data, 1);
  1734. // err = lfs_bd_prog(lfs, newblock, newoff, &data, 1);
  1735. // if (err) {
  1736. // return err;
  1737. // }
  1738. //
  1739. // oldoff += 1;
  1740. // newoff += 1;
  1741. // }
  1742. // }
  1743. //
  1744. // // sanity check our commit math
  1745. // LFS_ASSERT(newoff == newend);
  1746. // return 0;
  1747. //}
  1748. //
  1749. //static int lfs_dir_commit(lfs_t *lfs, lfs_dir_t *dir,
  1750. // const struct lfs_region *regions, int count) {
  1751. // // state for copying over
  1752. // const lfs_block_t oldpair[2] = {dir->pair[1], dir->pair[0]};
  1753. // bool relocated = false;
  1754. //
  1755. // // increment revision count
  1756. // dir->d.rev += 1;
  1757. //
  1758. // // keep pairs in order such that pair[0] is most recent
  1759. // lfs_pairswap(dir->pair);
  1760. // for (int i = 0; i < count; i++) {
  1761. // dir->d.size += regions[i].newsize;
  1762. // dir->d.size -= regions[i].oldsize;
  1763. // }
  1764. //
  1765. // while (true) {
  1766. // if (true) {
  1767. // int err = lfs_bd_erase(lfs, dir->pair[0]);
  1768. // if (err) {
  1769. // if (err == LFS_ERR_CORRUPT) {
  1770. // goto relocate;
  1771. // }
  1772. // return err;
  1773. // }
  1774. //
  1775. // // commit header
  1776. // uint32_t crc = 0xffffffff;
  1777. // lfs_dir_tole32(&dir->d);
  1778. // lfs_crc(&crc, &dir->d, sizeof(dir->d));
  1779. // err = lfs_bd_prog(lfs, dir->pair[0], 0, &dir->d, sizeof(dir->d));
  1780. // lfs_dir_fromle32(&dir->d);
  1781. // if (err) {
  1782. // if (err == LFS_ERR_CORRUPT) {
  1783. // goto relocate;
  1784. // }
  1785. // return err;
  1786. // }
  1787. //
  1788. // // commit entry
  1789. // err = lfs_commit_region(lfs, &crc,
  1790. // dir->pair[1], sizeof(dir->d),
  1791. // dir->pair[0], sizeof(dir->d),
  1792. // 0, (0x7fffffff & dir->d.size)-sizeof(dir->d)-4,
  1793. // regions, count);
  1794. // if (err) {
  1795. // if (err == LFS_ERR_CORRUPT) {
  1796. // goto relocate;
  1797. // }
  1798. // return err;
  1799. // }
  1800. //
  1801. // // commit crc
  1802. // crc = lfs_tole32(crc);
  1803. // err = lfs_bd_prog(lfs, dir->pair[0],
  1804. // (0x7fffffff & dir->d.size)-4, &crc, 4);
  1805. // crc = lfs_fromle32(crc);
  1806. // if (err) {
  1807. // if (err == LFS_ERR_CORRUPT) {
  1808. // goto relocate;
  1809. // }
  1810. // return err;
  1811. // }
  1812. //
  1813. // err = lfs_bd_sync(lfs);
  1814. // if (err) {
  1815. // if (err == LFS_ERR_CORRUPT) {
  1816. // goto relocate;
  1817. // }
  1818. // return err;
  1819. // }
  1820. //
  1821. // // successful commit, check checksum to make sure
  1822. // uint32_t ncrc = 0xffffffff;
  1823. // err = lfs_bd_crc(lfs, dir->pair[0], 0,
  1824. // (0x7fffffff & dir->d.size)-4, &ncrc);
  1825. // if (err) {
  1826. // return err;
  1827. // }
  1828. //
  1829. // if (ncrc != crc) {
  1830. // goto relocate;
  1831. // }
  1832. // }
  1833. //
  1834. // break;
  1835. //
  1836. //relocate:
  1837. // //commit was corrupted
  1838. // LFS_DEBUG("Bad block at %d", dir->pair[0]);
  1839. //
  1840. // // drop caches and prepare to relocate block
  1841. // relocated = true;
  1842. // lfs->pcache.block = 0xffffffff;
  1843. //
  1844. // // can't relocate superblock, filesystem is now frozen
  1845. // if (lfs_paircmp(oldpair, (const lfs_block_t[2]){0, 1}) == 0) {
  1846. // LFS_WARN("Superblock %d has become unwritable", oldpair[0]);
  1847. // return LFS_ERR_CORRUPT;
  1848. // }
  1849. //
  1850. // // relocate half of pair
  1851. // int err = lfs_alloc(lfs, &dir->pair[0]);
  1852. // if (err) {
  1853. // return err;
  1854. // }
  1855. // }
  1856. //
  1857. // if (relocated) {
  1858. // // update references if we relocated
  1859. // LFS_DEBUG("Relocating %d %d to %d %d",
  1860. // oldpair[0], oldpair[1], dir->pair[0], dir->pair[1]);
  1861. // int err = lfs_relocate(lfs, oldpair, dir->pair);
  1862. // if (err) {
  1863. // return err;
  1864. // }
  1865. // }
  1866. //
  1867. // // shift over any directories that are affected
  1868. // for (lfs_dir_t *d = lfs->dirs; d; d = d->next) {
  1869. // if (lfs_paircmp(d->pair, dir->pair) == 0) {
  1870. // d->pair[0] = dir->pair[0];
  1871. // d->pair[1] = dir->pair[1];
  1872. // }
  1873. // }
  1874. //
  1875. // return 0;
  1876. //}
  1877. //
  1878. //static int lfs_dir_get(lfs_t *lfs, const lfs_dir_t *dir,
  1879. // lfs_off_t off, void *buffer, lfs_size_t size) {
  1880. // return lfs_bd_read(lfs, dir->pair[0], off, buffer, size);
  1881. //}
  1882. //
  1883. //static int lfs_dir_set(lfs_t *lfs, lfs_dir_t *dir, lfs_entry_t *entry,
  1884. // struct lfs_region *regions, int count) {
  1885. // return -999;
  1886. //// lfs_ssize_t diff = 0;
  1887. //// for (int i = 0; i < count; i++) {
  1888. //// diff += regions[i].newsize;
  1889. //// diff -= regions[i].oldsize;
  1890. //// }
  1891. ////
  1892. //// lfs_size_t oldsize = entry->size;
  1893. //// if (entry->off == 0) {
  1894. //// entry->off = (0x7fffffff & dir->d.size) - 4;
  1895. //// }
  1896. ////
  1897. //// if ((0x7fffffff & dir->d.size) + diff > lfs->cfg->block_size) {
  1898. //// lfs_dir_t olddir = *dir;
  1899. //// lfs_off_t oldoff = entry->off;
  1900. ////
  1901. //// if (oldsize) {
  1902. //// // mark as moving
  1903. //// uint8_t type;
  1904. //// int err = lfs_dir_get(lfs, &olddir, oldoff, &type, 1);
  1905. //// if (err) {
  1906. //// return err;
  1907. //// }
  1908. ////
  1909. //// type |= LFS_STRUCT_MOVED;
  1910. //// err = lfs_dir_commit(lfs, &olddir, (struct lfs_region[]){
  1911. //// {LFS_FROM_MEM, oldoff, 1, &type, 1}}, 1);
  1912. //// if (err) {
  1913. //// return err;
  1914. //// }
  1915. //// }
  1916. ////
  1917. //// lfs_dir_t pdir = olddir;
  1918. ////
  1919. //// // find available block or create a new one
  1920. //// while ((0x7fffffff & dir->d.size) + oldsize + diff
  1921. //// > lfs->cfg->block_size) {
  1922. //// // we need to allocate a new dir block
  1923. //// if (!(0x80000000 & dir->d.size)) {
  1924. //// pdir = *dir;
  1925. //// int err = lfs_dir_alloc(lfs, dir);
  1926. //// if (err) {
  1927. //// return err;
  1928. //// }
  1929. ////
  1930. //// dir->d.tail[0] = pdir.d.tail[0];
  1931. //// dir->d.tail[1] = pdir.d.tail[1];
  1932. ////
  1933. //// break;
  1934. //// }
  1935. ////
  1936. //// int err = lfs_dir_fetch(lfs, dir, dir->d.tail);
  1937. //// if (err) {
  1938. //// return err;
  1939. //// }
  1940. //// }
  1941. ////
  1942. //// // writing out new entry
  1943. //// entry->off = dir->d.size - 4;
  1944. //// entry->size += diff;
  1945. //// int err = lfs_dir_commit(lfs, dir, (struct lfs_region[]){
  1946. //// {LFS_FROM_REGION, entry->off, 0, &(struct lfs_region_region){
  1947. //// olddir.pair[0], oldoff,
  1948. //// regions, count}, entry->size}}, 1);
  1949. //// if (err) {
  1950. //// return err;
  1951. //// }
  1952. ////
  1953. //// // update pred dir, unless pred == old we can coalesce
  1954. //// if (!oldsize || lfs_paircmp(pdir.pair, olddir.pair) != 0) {
  1955. //// pdir.d.size |= 0x80000000;
  1956. //// pdir.d.tail[0] = dir->pair[0];
  1957. //// pdir.d.tail[1] = dir->pair[1];
  1958. ////
  1959. //// err = lfs_dir_commit(lfs, &pdir, NULL, 0);
  1960. //// if (err) {
  1961. //// return err;
  1962. //// }
  1963. //// } else if (oldsize) {
  1964. //// olddir.d.size |= 0x80000000;
  1965. //// olddir.d.tail[0] = dir->pair[0];
  1966. //// olddir.d.tail[1] = dir->pair[1];
  1967. //// }
  1968. ////
  1969. //// // remove old entry
  1970. //// if (oldsize) {
  1971. //// lfs_entry_t oldentry;
  1972. //// oldentry.off = oldoff;
  1973. //// err = lfs_dir_set(lfs, &olddir, &oldentry, (struct lfs_region[]){
  1974. //// {LFS_FROM_MEM, 0, oldsize, NULL, 0}}, 1);
  1975. //// if (err) {
  1976. //// return err;
  1977. //// }
  1978. //// }
  1979. ////
  1980. //// goto shift;
  1981. //// }
  1982. ////
  1983. //// if ((0x7fffffff & dir->d.size) + diff == sizeof(dir->d)+4) {
  1984. //// lfs_dir_t pdir;
  1985. //// int res = lfs_pred(lfs, dir->pair, &pdir);
  1986. //// if (res < 0) {
  1987. //// return res;
  1988. //// }
  1989. ////
  1990. //// if (pdir.d.size & 0x80000000) {
  1991. //// pdir.d.size &= dir->d.size | 0x7fffffff;
  1992. //// pdir.d.tail[0] = dir->d.tail[0];
  1993. //// pdir.d.tail[1] = dir->d.tail[1];
  1994. //// int err = lfs_dir_commit(lfs, &pdir, NULL, 0);
  1995. //// if (err) {
  1996. //// return err;
  1997. //// }
  1998. //// goto shift;
  1999. //// }
  2000. //// }
  2001. ////
  2002. //// for (int i = 0; i < count; i++) {
  2003. //// regions[i].oldoff += entry->off;
  2004. //// }
  2005. ////
  2006. //// int err = lfs_dir_commit(lfs, dir, regions, count);
  2007. //// if (err) {
  2008. //// return err;
  2009. //// }
  2010. ////
  2011. //// entry->size += diff;
  2012. ////
  2013. ////shift:
  2014. //// // shift over any files/directories that are affected
  2015. //// for (lfs_file_t *f = lfs->files; f; f = f->next) {
  2016. //// if (lfs_paircmp(f->pair, dir->pair) == 0) {
  2017. //// if (f->pairoff == entry->off && entry->size == 0) {
  2018. //// f->pair[0] = 0xffffffff;
  2019. //// f->pair[1] = 0xffffffff;
  2020. //// } else if (f->pairoff > entry->off) {
  2021. //// f->pairoff += diff;
  2022. //// }
  2023. //// }
  2024. //// }
  2025. ////
  2026. //// for (lfs_dir_t *d = lfs->dirs; d; d = d->next) {
  2027. //// if (lfs_paircmp(d->pair, dir->pair) == 0) {
  2028. //// if (d->off > entry->off) {
  2029. //// d->off += diff;
  2030. //// d->pos += diff;
  2031. //// }
  2032. //// }
  2033. //// }
  2034. ////
  2035. //// return 0;
  2036. //}
  2037. //
  2038. //static int lfs_dir_next(lfs_t *lfs, lfs_dir_t *dir, lfs_entry_t *entry) {
  2039. // while (dir->off >= (0x7fffffff & dir->d.size)-4) {
  2040. // if (!(0x80000000 & dir->d.size)) {
  2041. // entry->off = dir->off;
  2042. // return LFS_ERR_NOENT;
  2043. // }
  2044. //
  2045. // int err = lfs_dir_fetch(lfs, dir, dir->d.tail);
  2046. // if (err) {
  2047. // return err;
  2048. // }
  2049. //
  2050. // dir->off = sizeof(dir->d);
  2051. // dir->pos += sizeof(dir->d) + 4;
  2052. // }
  2053. //
  2054. // int err = lfs_dir_get(lfs, dir, dir->off, &entry->d, sizeof(entry->d));
  2055. // lfs_entry_fromle32(&entry->d);
  2056. // if (err) {
  2057. // return err;
  2058. // }
  2059. //
  2060. // entry->off = dir->off;
  2061. // entry->size = lfs_entry_size(entry);
  2062. // dir->off += entry->size;
  2063. // dir->pos += entry->size;
  2064. // return 0;
  2065. //}
  2066. //
  2067. //static int lfs_dir_find(lfs_t *lfs, lfs_dir_t *dir,
  2068. // lfs_entry_t *entry, const char **path) {
  2069. // const char *pathname = *path;
  2070. // lfs_size_t pathlen;
  2071. //
  2072. // while (true) {
  2073. // nextname:
  2074. // // skip slashes
  2075. // pathname += strspn(pathname, "/");
  2076. // pathlen = strcspn(pathname, "/");
  2077. //
  2078. // // special case for root dir
  2079. // if (pathname[0] == '\0') {
  2080. // *entry = (lfs_entry_t){
  2081. // .d.type = LFS_STRUCT_DIR | LFS_TYPE_DIR,
  2082. // .d.u.dir[0] = lfs->root[0],
  2083. // .d.u.dir[1] = lfs->root[1],
  2084. // };
  2085. // return 0;
  2086. // }
  2087. //
  2088. // // skip '.' and root '..'
  2089. // if ((pathlen == 1 && memcmp(pathname, ".", 1) == 0) ||
  2090. // (pathlen == 2 && memcmp(pathname, "..", 2) == 0)) {
  2091. // pathname += pathlen;
  2092. // goto nextname;
  2093. // }
  2094. //
  2095. // // skip if matched by '..' in name
  2096. // const char *suffix = pathname + pathlen;
  2097. // lfs_size_t sufflen;
  2098. // int depth = 1;
  2099. // while (true) {
  2100. // suffix += strspn(suffix, "/");
  2101. // sufflen = strcspn(suffix, "/");
  2102. // if (sufflen == 0) {
  2103. // break;
  2104. // }
  2105. //
  2106. // if (sufflen == 2 && memcmp(suffix, "..", 2) == 0) {
  2107. // depth -= 1;
  2108. // if (depth == 0) {
  2109. // pathname = suffix + sufflen;
  2110. // goto nextname;
  2111. // }
  2112. // } else {
  2113. // depth += 1;
  2114. // }
  2115. //
  2116. // suffix += sufflen;
  2117. // }
  2118. //
  2119. // // update what we've found
  2120. // *path = pathname;
  2121. //
  2122. // // find path
  2123. // while (true) {
  2124. // int err = lfs_dir_next(lfs, dir, entry);
  2125. // if (err) {
  2126. // return err;
  2127. // }
  2128. //
  2129. // if (((0xf & entry->d.type) != LFS_TYPE_REG &&
  2130. // (0xf & entry->d.type) != LFS_TYPE_DIR) ||
  2131. // entry->d.nlen != pathlen) {
  2132. // continue;
  2133. // }
  2134. //
  2135. // int res = lfs_bd_cmp(lfs, dir->pair[0],
  2136. // entry->off + entry->size - pathlen,
  2137. // pathname, pathlen);
  2138. // if (res < 0) {
  2139. // return res;
  2140. // }
  2141. //
  2142. // // found match
  2143. // if (res) {
  2144. // break;
  2145. // }
  2146. // }
  2147. //
  2148. // // check that entry has not been moved
  2149. // if (entry->d.type & LFS_STRUCT_MOVED) {
  2150. // int moved = lfs_moved(lfs, &entry->d.u);
  2151. // if (moved < 0 || moved) {
  2152. // return (moved < 0) ? moved : LFS_ERR_NOENT;
  2153. // }
  2154. //
  2155. // entry->d.type &= ~LFS_STRUCT_MOVED;
  2156. // }
  2157. //
  2158. // pathname += pathlen;
  2159. // pathname += strspn(pathname, "/");
  2160. // if (pathname[0] == '\0') {
  2161. // return 0;
  2162. // }
  2163. //
  2164. // // continue on if we hit a directory
  2165. // if ((0xf & entry->d.type) != LFS_TYPE_DIR) {
  2166. // return LFS_ERR_NOTDIR;
  2167. // }
  2168. //
  2169. // int err = lfs_dir_fetch(lfs, dir, entry->d.u.dir);
  2170. // if (err) {
  2171. // return err;
  2172. // }
  2173. // }
  2174. //}
  2175. //
  2176. /// Internal attribute operations ///
  2177. //static int lfs_dir_getinfo(lfs_t *lfs,
  2178. // lfs_dir_t *dir, const lfs_entry_t *entry, struct lfs_info *info) {
  2179. // memset(info, 0, sizeof(*info));
  2180. // info->type = 0xf & entry->d.type;
  2181. // if (entry->d.type == (LFS_STRUCT_CTZ | LFS_TYPE_REG)) {
  2182. // info->size = entry->d.u.file.size;
  2183. // } else if (entry->d.type == (LFS_STRUCT_INLINE | LFS_TYPE_REG)) {
  2184. // info->size = lfs_entry_elen(entry);
  2185. // }
  2186. //
  2187. // if (lfs_paircmp(entry->d.u.dir, lfs->root) == 0) {
  2188. // strcpy(info->name, "/");
  2189. // } else {
  2190. // int err = lfs_dir_get(lfs, dir,
  2191. // entry->off + entry->size - entry->d.nlen,
  2192. // info->name, entry->d.nlen);
  2193. // if (err) {
  2194. // return err;
  2195. // }
  2196. // }
  2197. //
  2198. // return 0;
  2199. //}
  2200. //
  2201. //static int lfs_dir_getattrs(lfs_t *lfs,
  2202. // lfs_dir_t *dir, const lfs_entry_t *entry,
  2203. // const struct lfs_attr *attrs, int count) {
  2204. // // set to zero in case we can't find the attributes or size mismatch
  2205. // for (int j = 0; j < count; j++) {
  2206. // memset(attrs[j].buffer, 0, attrs[j].size);
  2207. // }
  2208. //
  2209. // // search for attribute in attribute entry
  2210. // lfs_off_t off = entry->off + 4+lfs_entry_elen(entry);
  2211. // lfs_off_t end = off + lfs_entry_alen(entry);
  2212. // while (off < end) {
  2213. // lfs_entry_attr_t attr;
  2214. // int err = lfs_dir_get(lfs, dir, off, &attr.d, sizeof(attr.d));
  2215. // if (err) {
  2216. // return err;
  2217. // }
  2218. //
  2219. // for (int j = 0; j < count; j++) {
  2220. // if (attrs[j].type == attr.d.type) {
  2221. // if (attrs[j].size < attr.d.len) {
  2222. // return LFS_ERR_RANGE;
  2223. // }
  2224. //
  2225. // err = lfs_dir_get(lfs, dir, off+sizeof(attr.d),
  2226. // attrs[j].buffer, attr.d.len);
  2227. // if (err) {
  2228. // return err;
  2229. // }
  2230. // }
  2231. // }
  2232. //
  2233. // off += 2+attr.d.len;
  2234. // }
  2235. //
  2236. // return 0;
  2237. //}
  2238. //
  2239. //static lfs_ssize_t lfs_dir_checkattrs(lfs_t *lfs,
  2240. // lfs_dir_t *dir, lfs_entry_t *entry,
  2241. // const struct lfs_attr *attrs, int count) {
  2242. // // check that attributes fit
  2243. // // two separate passes so disk access is O(n)
  2244. // lfs_size_t nsize = 0;
  2245. // for (int j = 0; j < count; j++) {
  2246. // if (attrs[j].size > 0) {
  2247. // nsize += 2+attrs[j].size;
  2248. // }
  2249. // }
  2250. //
  2251. // lfs_off_t off = entry->off + 4+lfs_entry_elen(entry);
  2252. // lfs_off_t end = off + lfs_entry_alen(entry);
  2253. // while (off < end) {
  2254. // lfs_entry_attr_t attr;
  2255. // int err = lfs_dir_get(lfs, dir, off, &attr.d, sizeof(attr.d));
  2256. // if (err) {
  2257. // return err;
  2258. // }
  2259. //
  2260. // bool updated = false;
  2261. // for (int j = 0; j < count; j++) {
  2262. // if (attr.d.type == attrs[j].type) {
  2263. // updated = true;
  2264. // }
  2265. // }
  2266. //
  2267. // if (!updated) {
  2268. // nsize += 2+attr.d.len;
  2269. // }
  2270. //
  2271. // off += 2+attr.d.len;
  2272. // }
  2273. //
  2274. // if (nsize > lfs->attrs_size || (
  2275. // lfs_entry_size(entry) - lfs_entry_alen(entry) + nsize
  2276. // > lfs->cfg->block_size)) {
  2277. // return LFS_ERR_NOSPC;
  2278. // }
  2279. //
  2280. // return nsize;
  2281. //}
  2282. //
  2283. //static int lfs_dir_setattrs(lfs_t *lfs,
  2284. // lfs_dir_t *dir, lfs_entry_t *entry,
  2285. // const struct lfs_attr *attrs, int count) {
  2286. // // make sure attributes fit
  2287. // lfs_size_t oldlen = lfs_entry_alen(entry);
  2288. // lfs_ssize_t newlen = lfs_dir_checkattrs(lfs, dir, entry, attrs, count);
  2289. // if (newlen < 0) {
  2290. // return newlen;
  2291. // }
  2292. //
  2293. // // commit to entry, majority of work is in LFS_FROM_ATTRS
  2294. // entry->d.alen = (0xc0 & entry->d.alen) | newlen;
  2295. // return lfs_dir_set(lfs, dir, entry, (struct lfs_region[]){
  2296. // {LFS_FROM_MEM, 0, 4, &entry->d, 4},
  2297. // {LFS_FROM_ATTRS, 4+lfs_entry_elen(entry), oldlen,
  2298. // &(struct lfs_region_attrs){attrs, count}, newlen}}, 2);
  2299. //}
  2300. //
  2301. /// Top level directory operations ///
  2302. int lfs_mkdir(lfs_t *lfs, const char *path) {
  2303. // deorphan if we haven't yet, needed at most once after poweron
  2304. if (!lfs->deorphaned) {
  2305. int err = lfs_deorphan(lfs);
  2306. if (err) {
  2307. return err;
  2308. }
  2309. }
  2310. lfs_dir_t cwd;
  2311. int err = lfs_dir_find(lfs, &cwd, &path, &(int16_t){0});
  2312. if (err != LFS_ERR_NOENT || strchr(path, '/') != NULL) {
  2313. if (!err) {
  2314. return LFS_ERR_EXIST;
  2315. }
  2316. return err;
  2317. }
  2318. // check that name fits
  2319. lfs_size_t nlen = strlen(path);
  2320. if (nlen > lfs->name_size) {
  2321. return LFS_ERR_NAMETOOLONG;
  2322. }
  2323. // build up new directory
  2324. lfs_alloc_ack(lfs);
  2325. lfs_dir_t dir;
  2326. err = lfs_dir_alloc(lfs, &dir, false, cwd.tail);
  2327. if (err) {
  2328. return err;
  2329. }
  2330. err = lfs_dir_commit_(lfs, &dir, NULL);
  2331. if (err) {
  2332. return err;
  2333. }
  2334. // get next slot and commit
  2335. uint16_t id;
  2336. err = lfs_dir_append(lfs, &cwd, &id);
  2337. if (err) {
  2338. return err;
  2339. }
  2340. cwd.tail[0] = dir.pair[0];
  2341. cwd.tail[1] = dir.pair[1];
  2342. err = lfs_dir_commit_(lfs, &cwd, &(lfs_entrylist_t){
  2343. {lfs_mktag(LFS_TYPE_NAME, id, nlen),
  2344. .u.buffer=(void*)path}, &(lfs_entrylist_t){
  2345. {lfs_mktag(LFS_TYPE_DIR | LFS_STRUCT_DIR, id, sizeof(dir.pair)),
  2346. .u.buffer=dir.pair}, &(lfs_entrylist_t){
  2347. {lfs_mktag(LFS_TYPE_SOFTTAIL, 0x1ff, sizeof(cwd.tail)),
  2348. .u.buffer=cwd.tail}}}});
  2349. // TODO need ack here?
  2350. lfs_alloc_ack(lfs);
  2351. return 0;
  2352. }
  2353. //int lfs_mkdir(lfs_t *lfs, const char *path) {
  2354. // // deorphan if we haven't yet, needed at most once after poweron
  2355. // if (!lfs->deorphaned) {
  2356. // int err = lfs_deorphan(lfs);
  2357. // if (err) {
  2358. // return err;
  2359. // }
  2360. // }
  2361. //
  2362. // // fetch parent directory
  2363. // lfs_dir_t cwd;
  2364. // int err = lfs_dir_fetch(lfs, &cwd, lfs->root);
  2365. // if (err) {
  2366. // return err;
  2367. // }
  2368. //
  2369. // lfs_entry_t entry;
  2370. // err = lfs_dir_find(lfs, &cwd, &entry, &path);
  2371. // if (err != LFS_ERR_NOENT || strchr(path, '/') != NULL) {
  2372. // return err ? err : LFS_ERR_EXIST;
  2373. // }
  2374. //
  2375. // // check that name fits
  2376. // lfs_size_t nlen = strlen(path);
  2377. // if (nlen > lfs->name_size) {
  2378. // return LFS_ERR_NAMETOOLONG;
  2379. // }
  2380. //
  2381. // // build up new directory
  2382. // lfs_alloc_ack(lfs);
  2383. //
  2384. // lfs_dir_t dir;
  2385. // err = lfs_dir_alloc(lfs, &dir);
  2386. // if (err) {
  2387. // return err;
  2388. // }
  2389. // dir.d.tail[0] = cwd.d.tail[0];
  2390. // dir.d.tail[1] = cwd.d.tail[1];
  2391. //
  2392. // err = lfs_dir_commit(lfs, &dir, NULL, 0);
  2393. // if (err) {
  2394. // return err;
  2395. // }
  2396. //
  2397. // entry.d.type = LFS_STRUCT_DIR | LFS_TYPE_DIR;
  2398. // entry.d.elen = sizeof(entry.d) - 4;
  2399. // entry.d.alen = 0;
  2400. // entry.d.nlen = nlen;
  2401. // entry.d.u.dir[0] = dir.pair[0];
  2402. // entry.d.u.dir[1] = dir.pair[1];
  2403. // entry.size = 0;
  2404. //
  2405. // cwd.d.tail[0] = dir.pair[0];
  2406. // cwd.d.tail[1] = dir.pair[1];
  2407. // lfs_entry_tole32(&entry.d);
  2408. // err = lfs_dir_set(lfs, &cwd, &entry, (struct lfs_region[]){
  2409. // {LFS_FROM_MEM, 0, 0, &entry.d, sizeof(entry.d)},
  2410. // {LFS_FROM_MEM, 0, 0, path, nlen}}, 2);
  2411. // if (err) {
  2412. // return err;
  2413. // }
  2414. //
  2415. // lfs_alloc_ack(lfs);
  2416. // return 0;
  2417. //}
  2418. int lfs_dir_open(lfs_t *lfs, lfs_dir_t *dir, const char *path) {
  2419. int16_t id;
  2420. int err = lfs_dir_find(lfs, dir, &path, &id);
  2421. if (err) {
  2422. return err;
  2423. }
  2424. lfs_entry_t entry;
  2425. if (id < 0) {
  2426. // handle root dir separately
  2427. entry.u.pair[0] = lfs->root[0];
  2428. entry.u.pair[1] = lfs->root[1];
  2429. } else {
  2430. // get dir pair from parent
  2431. err = lfs_dir_getentry(lfs, dir, 0x701ff000,
  2432. lfs_mktag(LFS_TYPE_REG, id, 0), &entry);
  2433. if (err) {
  2434. return err;
  2435. }
  2436. if (lfs_tag_subtype(entry.tag) != LFS_TYPE_DIR) {
  2437. return LFS_ERR_NOTDIR;
  2438. }
  2439. }
  2440. // fetch first pair
  2441. err = lfs_dir_fetch(lfs, dir, entry.u.pair);
  2442. if (err) {
  2443. return err;
  2444. }
  2445. // setup head dir
  2446. dir->head[0] = dir->pair[0];
  2447. dir->head[1] = dir->pair[1];
  2448. dir->pos = 0;
  2449. dir->id = 0;
  2450. // add to list of directories
  2451. dir->next = lfs->dirs;
  2452. lfs->dirs = dir;
  2453. return 0;
  2454. }
  2455. int lfs_dir_close(lfs_t *lfs, lfs_dir_t *dir) {
  2456. // remove from list of directories
  2457. for (lfs_dir_t **p = &lfs->dirs; *p; p = &(*p)->next) {
  2458. if (*p == dir) {
  2459. *p = dir->next;
  2460. break;
  2461. }
  2462. }
  2463. return 0;
  2464. }
  2465. int lfs_dir_read(lfs_t *lfs, lfs_dir_t *dir, struct lfs_info *info) {
  2466. memset(info, 0, sizeof(*info));
  2467. // special offset for '.' and '..'
  2468. if (dir->pos == 0) {
  2469. info->type = LFS_TYPE_DIR;
  2470. strcpy(info->name, ".");
  2471. dir->pos += 1;
  2472. return 1;
  2473. } else if (dir->pos == 1) {
  2474. info->type = LFS_TYPE_DIR;
  2475. strcpy(info->name, "..");
  2476. dir->pos += 1;
  2477. return 1;
  2478. }
  2479. while (true) {
  2480. if (dir->id == dir->count) {
  2481. if (!dir->split) {
  2482. return false;
  2483. }
  2484. int err = lfs_dir_fetch(lfs, dir, dir->tail);
  2485. if (err) {
  2486. return err;
  2487. }
  2488. dir->id = 0;
  2489. }
  2490. int err = lfs_dir_getinfo(lfs, dir, dir->id, info);
  2491. if (err && err != LFS_ERR_NOENT) {
  2492. return err;
  2493. }
  2494. dir->id += 1;
  2495. if (err != LFS_ERR_NOENT) {
  2496. break;
  2497. }
  2498. }
  2499. dir->pos += 1;
  2500. return true;
  2501. }
  2502. // TODO does this work?
  2503. int lfs_dir_seek(lfs_t *lfs, lfs_dir_t *dir, lfs_off_t off) {
  2504. // simply walk from head dir
  2505. int err = lfs_dir_rewind(lfs, dir);
  2506. if (err) {
  2507. return err;
  2508. }
  2509. // first two for ./..
  2510. dir->id = lfs_min(2 + dir->count, off);
  2511. dir->pos += dir->id;
  2512. off -= dir->id;
  2513. while (off != 0) {
  2514. if (dir->id == dir->count) {
  2515. if (!dir->split) {
  2516. return LFS_ERR_INVAL;
  2517. }
  2518. int err = lfs_dir_fetch(lfs, dir, dir->tail);
  2519. if (err) {
  2520. return err;
  2521. }
  2522. }
  2523. dir->id = lfs_min(dir->count, off);
  2524. dir->pos += dir->id;
  2525. off -= dir->id;
  2526. }
  2527. return 0;
  2528. }
  2529. lfs_soff_t lfs_dir_tell(lfs_t *lfs, lfs_dir_t *dir) {
  2530. (void)lfs;
  2531. return dir->pos;
  2532. }
  2533. int lfs_dir_rewind(lfs_t *lfs, lfs_dir_t *dir) {
  2534. // reload the head dir
  2535. int err = lfs_dir_fetch(lfs, dir, dir->head);
  2536. if (err) {
  2537. return err;
  2538. }
  2539. dir->pair[0] = dir->head[0];
  2540. dir->pair[1] = dir->head[1];
  2541. dir->pos = 0;
  2542. dir->id = 0;
  2543. return 0;
  2544. }
  2545. //int lfs_dir_open(lfs_t *lfs, lfs_dir_t *dir, const char *path) {
  2546. // dir->pair[0] = lfs->root[0];
  2547. // dir->pair[1] = lfs->root[1];
  2548. //
  2549. // int err = lfs_dir_fetch(lfs, dir, dir->pair);
  2550. // if (err) {
  2551. // return err;
  2552. // }
  2553. //
  2554. // lfs_entry_t entry;
  2555. // err = lfs_dir_find(lfs, dir, &entry, &path);
  2556. // if (err) {
  2557. // return err;
  2558. // } else if (entry.d.type != (LFS_STRUCT_DIR | LFS_TYPE_DIR)) {
  2559. // return LFS_ERR_NOTDIR;
  2560. // }
  2561. //
  2562. // err = lfs_dir_fetch(lfs, dir, entry.d.u.dir);
  2563. // if (err) {
  2564. // return err;
  2565. // }
  2566. //
  2567. // // setup head dir
  2568. // // special offset for '.' and '..'
  2569. // dir->head[0] = dir->pair[0];
  2570. // dir->head[1] = dir->pair[1];
  2571. // dir->pos = sizeof(dir->d) - 2;
  2572. // dir->off = sizeof(dir->d);
  2573. //
  2574. // // add to list of directories
  2575. // dir->next = lfs->dirs;
  2576. // lfs->dirs = dir;
  2577. //
  2578. // return 0;
  2579. //}
  2580. //
  2581. //int lfs_dir_close(lfs_t *lfs, lfs_dir_t *dir) {
  2582. // // remove from list of directories
  2583. // for (lfs_dir_t **p = &lfs->dirs; *p; p = &(*p)->next) {
  2584. // if (*p == dir) {
  2585. // *p = dir->next;
  2586. // break;
  2587. // }
  2588. // }
  2589. //
  2590. // return 0;
  2591. //}
  2592. //
  2593. //int lfs_dir_read(lfs_t *lfs, lfs_dir_t *dir, struct lfs_info *info) {
  2594. // memset(info, 0, sizeof(*info));
  2595. //
  2596. // // special offset for '.' and '..'
  2597. // if (dir->pos == sizeof(dir->d) - 2) {
  2598. // info->type = LFS_TYPE_DIR;
  2599. // strcpy(info->name, ".");
  2600. // dir->pos += 1;
  2601. // return 1;
  2602. // } else if (dir->pos == sizeof(dir->d) - 1) {
  2603. // info->type = LFS_TYPE_DIR;
  2604. // strcpy(info->name, "..");
  2605. // dir->pos += 1;
  2606. // return 1;
  2607. // }
  2608. //
  2609. // lfs_entry_t entry;
  2610. // while (true) {
  2611. // int err = lfs_dir_next(lfs, dir, &entry);
  2612. // if (err) {
  2613. // return (err == LFS_ERR_NOENT) ? 0 : err;
  2614. // }
  2615. //
  2616. // if ((0xf & entry.d.type) != LFS_TYPE_REG &&
  2617. // (0xf & entry.d.type) != LFS_TYPE_DIR) {
  2618. // continue;
  2619. // }
  2620. //
  2621. // // check that entry has not been moved
  2622. // if (entry.d.type & LFS_STRUCT_MOVED) {
  2623. // int moved = lfs_moved(lfs, &entry.d.u);
  2624. // if (moved < 0) {
  2625. // return moved;
  2626. // }
  2627. //
  2628. // if (moved) {
  2629. // continue;
  2630. // }
  2631. //
  2632. // entry.d.type &= ~LFS_STRUCT_MOVED;
  2633. // }
  2634. //
  2635. // break;
  2636. // }
  2637. //
  2638. // int err = lfs_dir_getinfo(lfs, dir, &entry, info);
  2639. // if (err) {
  2640. // return err;
  2641. // }
  2642. //
  2643. // return 1;
  2644. //}
  2645. //
  2646. //int lfs_dir_seek(lfs_t *lfs, lfs_dir_t *dir, lfs_off_t off) {
  2647. // // simply walk from head dir
  2648. // int err = lfs_dir_rewind(lfs, dir);
  2649. // if (err) {
  2650. // return err;
  2651. // }
  2652. // dir->pos = off;
  2653. //
  2654. // while (off > (0x7fffffff & dir->d.size)) {
  2655. // off -= 0x7fffffff & dir->d.size;
  2656. // if (!(0x80000000 & dir->d.size)) {
  2657. // return LFS_ERR_INVAL;
  2658. // }
  2659. //
  2660. // err = lfs_dir_fetch(lfs, dir, dir->d.tail);
  2661. // if (err) {
  2662. // return err;
  2663. // }
  2664. // }
  2665. //
  2666. // dir->off = off;
  2667. // return 0;
  2668. //}
  2669. //
  2670. //lfs_soff_t lfs_dir_tell(lfs_t *lfs, lfs_dir_t *dir) {
  2671. // (void)lfs;
  2672. // return dir->pos;
  2673. //}
  2674. //
  2675. //int lfs_dir_rewind(lfs_t *lfs, lfs_dir_t *dir) {
  2676. // // reload the head dir
  2677. // int err = lfs_dir_fetch(lfs, dir, dir->head);
  2678. // if (err) {
  2679. // return err;
  2680. // }
  2681. //
  2682. // dir->pair[0] = dir->head[0];
  2683. // dir->pair[1] = dir->head[1];
  2684. // dir->pos = sizeof(dir->d) - 2;
  2685. // dir->off = sizeof(dir->d);
  2686. // return 0;
  2687. //}
  2688. /// File index list operations ///
  2689. static int lfs_ctz_index(lfs_t *lfs, lfs_off_t *off) {
  2690. lfs_off_t size = *off;
  2691. lfs_off_t b = lfs->cfg->block_size - 2*4;
  2692. lfs_off_t i = size / b;
  2693. if (i == 0) {
  2694. return 0;
  2695. }
  2696. i = (size - 4*(lfs_popc(i-1)+2)) / b;
  2697. *off = size - b*i - 4*lfs_popc(i);
  2698. return i;
  2699. }
  2700. static int lfs_ctz_find(lfs_t *lfs,
  2701. lfs_cache_t *rcache, const lfs_cache_t *pcache,
  2702. lfs_block_t head, lfs_size_t size,
  2703. lfs_size_t pos, lfs_block_t *block, lfs_off_t *off) {
  2704. if (size == 0) {
  2705. *block = 0xffffffff;
  2706. *off = 0;
  2707. return 0;
  2708. }
  2709. lfs_off_t current = lfs_ctz_index(lfs, &(lfs_off_t){size-1});
  2710. lfs_off_t target = lfs_ctz_index(lfs, &pos);
  2711. while (current > target) {
  2712. lfs_size_t skip = lfs_min(
  2713. lfs_npw2(current-target+1) - 1,
  2714. lfs_ctz(current));
  2715. int err = lfs_cache_read(lfs, rcache, pcache, head, 4*skip, &head, 4);
  2716. head = lfs_fromle32(head);
  2717. if (err) {
  2718. return err;
  2719. }
  2720. LFS_ASSERT(head >= 2 && head <= lfs->cfg->block_count);
  2721. current -= 1 << skip;
  2722. }
  2723. *block = head;
  2724. *off = pos;
  2725. return 0;
  2726. }
  2727. static int lfs_ctz_extend(lfs_t *lfs,
  2728. lfs_cache_t *rcache, lfs_cache_t *pcache,
  2729. lfs_block_t head, lfs_size_t size,
  2730. lfs_block_t *block, lfs_off_t *off) {
  2731. while (true) {
  2732. // go ahead and grab a block
  2733. lfs_block_t nblock;
  2734. int err = lfs_alloc(lfs, &nblock);
  2735. if (err) {
  2736. return err;
  2737. }
  2738. LFS_ASSERT(nblock >= 2 && nblock <= lfs->cfg->block_count);
  2739. if (true) {
  2740. err = lfs_bd_erase(lfs, nblock);
  2741. if (err) {
  2742. if (err == LFS_ERR_CORRUPT) {
  2743. goto relocate;
  2744. }
  2745. return err;
  2746. }
  2747. if (size == 0) {
  2748. *block = nblock;
  2749. *off = 0;
  2750. return 0;
  2751. }
  2752. size -= 1;
  2753. lfs_off_t index = lfs_ctz_index(lfs, &size);
  2754. size += 1;
  2755. // just copy out the last block if it is incomplete
  2756. if (size != lfs->cfg->block_size) {
  2757. for (lfs_off_t i = 0; i < size; i++) {
  2758. uint8_t data;
  2759. err = lfs_cache_read(lfs, rcache, NULL,
  2760. head, i, &data, 1);
  2761. if (err) {
  2762. return err;
  2763. }
  2764. err = lfs_cache_prog(lfs, pcache, rcache,
  2765. nblock, i, &data, 1);
  2766. if (err) {
  2767. if (err == LFS_ERR_CORRUPT) {
  2768. goto relocate;
  2769. }
  2770. return err;
  2771. }
  2772. }
  2773. *block = nblock;
  2774. *off = size;
  2775. return 0;
  2776. }
  2777. // append block
  2778. index += 1;
  2779. lfs_size_t skips = lfs_ctz(index) + 1;
  2780. for (lfs_off_t i = 0; i < skips; i++) {
  2781. head = lfs_tole32(head);
  2782. err = lfs_cache_prog(lfs, pcache, rcache,
  2783. nblock, 4*i, &head, 4);
  2784. head = lfs_fromle32(head);
  2785. if (err) {
  2786. if (err == LFS_ERR_CORRUPT) {
  2787. goto relocate;
  2788. }
  2789. return err;
  2790. }
  2791. if (i != skips-1) {
  2792. err = lfs_cache_read(lfs, rcache, NULL,
  2793. head, 4*i, &head, 4);
  2794. head = lfs_fromle32(head);
  2795. if (err) {
  2796. return err;
  2797. }
  2798. }
  2799. LFS_ASSERT(head >= 2 && head <= lfs->cfg->block_count);
  2800. }
  2801. *block = nblock;
  2802. *off = 4*skips;
  2803. return 0;
  2804. }
  2805. relocate:
  2806. LFS_DEBUG("Bad block at %d", nblock);
  2807. // just clear cache and try a new block
  2808. pcache->block = 0xffffffff;
  2809. }
  2810. }
  2811. static int lfs_ctz_traverse(lfs_t *lfs,
  2812. lfs_cache_t *rcache, const lfs_cache_t *pcache,
  2813. lfs_block_t head, lfs_size_t size,
  2814. int (*cb)(lfs_t*, void*, lfs_block_t), void *data) {
  2815. if (size == 0) {
  2816. return 0;
  2817. }
  2818. lfs_off_t index = lfs_ctz_index(lfs, &(lfs_off_t){size-1});
  2819. while (true) {
  2820. int err = cb(lfs, data, head);
  2821. if (err) {
  2822. return err;
  2823. }
  2824. if (index == 0) {
  2825. return 0;
  2826. }
  2827. lfs_block_t heads[2];
  2828. int count = 2 - (index & 1);
  2829. err = lfs_cache_read(lfs, rcache, pcache, head, 0, &heads, count*4);
  2830. heads[0] = lfs_fromle32(heads[0]);
  2831. heads[1] = lfs_fromle32(heads[1]);
  2832. if (err) {
  2833. return err;
  2834. }
  2835. for (int i = 0; i < count-1; i++) {
  2836. err = cb(lfs, data, heads[i]);
  2837. if (err) {
  2838. return err;
  2839. }
  2840. }
  2841. head = heads[count-1];
  2842. index -= count;
  2843. }
  2844. }
  2845. /// Top level file operations ///
  2846. int lfs_file_open(lfs_t *lfs, lfs_file_t *file,
  2847. const char *path, int flags) {
  2848. // deorphan if we haven't yet, needed at most once after poweron
  2849. if ((flags & 3) != LFS_O_RDONLY && !lfs->deorphaned) {
  2850. int err = lfs_deorphan(lfs);
  2851. if (err) {
  2852. return err;
  2853. }
  2854. }
  2855. // allocate entry for file if it doesn't exist
  2856. lfs_dir_t cwd;
  2857. int16_t id;
  2858. int err = lfs_dir_find(lfs, &cwd, &path, &id);
  2859. if (err && (err != LFS_ERR_NOENT || strchr(path, '/') != NULL)) {
  2860. return err;
  2861. }
  2862. lfs_entry_t entry;
  2863. if (err == LFS_ERR_NOENT) {
  2864. if (!(flags & LFS_O_CREAT)) {
  2865. return LFS_ERR_NOENT;
  2866. }
  2867. // check that name fits
  2868. lfs_size_t nlen = strlen(path);
  2869. if (nlen > lfs->name_size) {
  2870. return LFS_ERR_NAMETOOLONG;
  2871. }
  2872. // get next slot and create entry to remember name
  2873. err = lfs_dir_append(lfs, &cwd, &id);
  2874. if (err) {
  2875. return err;
  2876. }
  2877. err = lfs_dir_commit_(lfs, &cwd, &(lfs_entrylist_t){
  2878. {lfs_mktag(LFS_TYPE_NAME, id, nlen),
  2879. .u.buffer=(void*)path}, &(lfs_entrylist_t){
  2880. {lfs_mktag(LFS_TYPE_REG | LFS_STRUCT_INLINE, id, 0)}}});
  2881. if (err) {
  2882. return err;
  2883. }
  2884. entry.tag = lfs_mktag(LFS_TYPE_REG | LFS_STRUCT_INLINE, id, 0);
  2885. } else {
  2886. if (flags & LFS_O_EXCL) {
  2887. return LFS_ERR_EXIST;
  2888. }
  2889. entry.tag = lfs_mktag(LFS_TYPE_REG, id, 0);
  2890. err = lfs_dir_get(lfs, &cwd, 0x701ff000, &entry);
  2891. if (err) {
  2892. return err;
  2893. }
  2894. if (lfs_tag_subtype(entry.tag) != LFS_TYPE_REG) {
  2895. return LFS_ERR_ISDIR;
  2896. }
  2897. }
  2898. // setup file struct
  2899. file->pair[0] = cwd.pair[0];
  2900. file->pair[1] = cwd.pair[1];
  2901. file->id = id;
  2902. file->flags = flags;
  2903. file->pos = 0;
  2904. file->attrs = NULL;
  2905. // allocate buffer if needed
  2906. file->cache.block = 0xffffffff;
  2907. if (lfs->cfg->file_buffer) {
  2908. file->cache.buffer = lfs->cfg->file_buffer;
  2909. } else if ((file->flags & 3) == LFS_O_RDONLY) {
  2910. file->cache.buffer = lfs_malloc(lfs->cfg->read_size);
  2911. if (!file->cache.buffer) {
  2912. return LFS_ERR_NOMEM;
  2913. }
  2914. } else {
  2915. file->cache.buffer = lfs_malloc(lfs->cfg->prog_size);
  2916. if (!file->cache.buffer) {
  2917. return LFS_ERR_NOMEM;
  2918. }
  2919. }
  2920. if (lfs_tag_struct(entry.tag) == LFS_STRUCT_INLINE) {
  2921. // load inline files
  2922. file->head = 0xfffffffe;
  2923. file->size = lfs_tag_size(entry.tag);
  2924. file->flags |= LFS_F_INLINE;
  2925. file->cache.block = file->head;
  2926. file->cache.off = 0;
  2927. // don't always read (may be new file)
  2928. if (file->size > 0) {
  2929. err = lfs_bd_read(lfs, entry.u.d.block, entry.u.d.off,
  2930. file->cache.buffer, file->size);
  2931. if (err) {
  2932. lfs_free(file->cache.buffer);
  2933. return err;
  2934. }
  2935. }
  2936. } else {
  2937. // use ctz list from entry
  2938. err = lfs_bd_read(lfs, entry.u.d.block, entry.u.d.off,
  2939. &file->head, 2*sizeof(uint32_t));
  2940. }
  2941. // truncate if requested
  2942. if (flags & LFS_O_TRUNC) {
  2943. if (file->size != 0) {
  2944. file->flags |= LFS_F_DIRTY;
  2945. }
  2946. file->head = 0xfffffffe;
  2947. file->size = 0;
  2948. file->flags |= LFS_F_INLINE;
  2949. file->cache.block = file->head;
  2950. file->cache.off = 0;
  2951. }
  2952. // add to list of files
  2953. file->next = lfs->files;
  2954. lfs->files = file;
  2955. return 0;
  2956. }
  2957. int lfs_file_close(lfs_t *lfs, lfs_file_t *file) {
  2958. int err = lfs_file_sync(lfs, file);
  2959. // remove from list of files
  2960. for (lfs_file_t **p = &lfs->files; *p; p = &(*p)->next) {
  2961. if (*p == file) {
  2962. *p = file->next;
  2963. break;
  2964. }
  2965. }
  2966. // clean up memory
  2967. if (!lfs->cfg->file_buffer) {
  2968. lfs_free(file->cache.buffer);
  2969. }
  2970. return err;
  2971. }
  2972. static int lfs_file_relocate(lfs_t *lfs, lfs_file_t *file) {
  2973. relocate:;
  2974. // just relocate what exists into new block
  2975. lfs_block_t nblock;
  2976. int err = lfs_alloc(lfs, &nblock);
  2977. if (err) {
  2978. return err;
  2979. }
  2980. err = lfs_bd_erase(lfs, nblock);
  2981. if (err) {
  2982. if (err == LFS_ERR_CORRUPT) {
  2983. goto relocate;
  2984. }
  2985. return err;
  2986. }
  2987. // either read from dirty cache or disk
  2988. for (lfs_off_t i = 0; i < file->off; i++) {
  2989. uint8_t data;
  2990. err = lfs_cache_read(lfs, &lfs->rcache, &file->cache,
  2991. file->block, i, &data, 1);
  2992. if (err) {
  2993. return err;
  2994. }
  2995. err = lfs_cache_prog(lfs, &lfs->pcache, &lfs->rcache,
  2996. nblock, i, &data, 1);
  2997. if (err) {
  2998. if (err == LFS_ERR_CORRUPT) {
  2999. goto relocate;
  3000. }
  3001. return err;
  3002. }
  3003. }
  3004. // copy over new state of file
  3005. memcpy(file->cache.buffer, lfs->pcache.buffer, lfs->cfg->prog_size);
  3006. file->cache.block = lfs->pcache.block;
  3007. file->cache.off = lfs->pcache.off;
  3008. lfs->pcache.block = 0xffffffff;
  3009. file->block = nblock;
  3010. return 0;
  3011. }
  3012. static int lfs_file_flush(lfs_t *lfs, lfs_file_t *file) {
  3013. if (file->flags & LFS_F_READING) {
  3014. file->flags &= ~LFS_F_READING;
  3015. }
  3016. if (file->flags & LFS_F_WRITING) {
  3017. lfs_off_t pos = file->pos;
  3018. if (!(file->flags & LFS_F_INLINE)) {
  3019. // copy over anything after current branch
  3020. lfs_file_t orig = {
  3021. .head = file->head,
  3022. .size = file->size,
  3023. .flags = LFS_O_RDONLY,
  3024. .pos = file->pos,
  3025. .cache = lfs->rcache,
  3026. };
  3027. lfs->rcache.block = 0xffffffff;
  3028. while (file->pos < file->size) {
  3029. // copy over a byte at a time, leave it up to caching
  3030. // to make this efficient
  3031. uint8_t data;
  3032. lfs_ssize_t res = lfs_file_read(lfs, &orig, &data, 1);
  3033. if (res < 0) {
  3034. return res;
  3035. }
  3036. res = lfs_file_write(lfs, file, &data, 1);
  3037. if (res < 0) {
  3038. return res;
  3039. }
  3040. // keep our reference to the rcache in sync
  3041. if (lfs->rcache.block != 0xffffffff) {
  3042. orig.cache.block = 0xffffffff;
  3043. lfs->rcache.block = 0xffffffff;
  3044. }
  3045. }
  3046. // write out what we have
  3047. while (true) {
  3048. int err = lfs_cache_flush(lfs, &file->cache, &lfs->rcache);
  3049. if (err) {
  3050. if (err == LFS_ERR_CORRUPT) {
  3051. goto relocate;
  3052. }
  3053. return err;
  3054. }
  3055. break;
  3056. relocate:
  3057. LFS_DEBUG("Bad block at %d", file->block);
  3058. err = lfs_file_relocate(lfs, file);
  3059. if (err) {
  3060. return err;
  3061. }
  3062. }
  3063. } else {
  3064. file->size = lfs_max(file->pos, file->size);
  3065. }
  3066. // actual file updates
  3067. file->head = file->block;
  3068. file->size = file->pos;
  3069. file->flags &= ~LFS_F_WRITING;
  3070. file->flags |= LFS_F_DIRTY;
  3071. file->pos = pos;
  3072. }
  3073. return 0;
  3074. }
  3075. int lfs_file_sync(lfs_t *lfs, lfs_file_t *file) {
  3076. int err = lfs_file_flush(lfs, file);
  3077. if (err) {
  3078. return err;
  3079. }
  3080. if ((file->flags & LFS_F_DIRTY) &&
  3081. !(file->flags & LFS_F_ERRED) &&
  3082. !lfs_pairisnull(file->pair)) {
  3083. // update dir entry
  3084. // TODO keep list of dirs including these guys for no
  3085. // need of another reload?
  3086. lfs_dir_t cwd;
  3087. err = lfs_dir_fetch(lfs, &cwd, file->pair);
  3088. if (err) {
  3089. return err;
  3090. }
  3091. // either update the references or inline the whole file
  3092. if (!(file->flags & LFS_F_INLINE)) {
  3093. int err = lfs_dir_commit_(lfs, &cwd, &(lfs_entrylist_t){
  3094. {lfs_mktag(LFS_TYPE_REG | LFS_STRUCT_CTZ, file->id,
  3095. 2*sizeof(uint32_t)), .u.buffer=&file->head},
  3096. file->attrs});
  3097. if (err) {
  3098. return err;
  3099. }
  3100. } else {
  3101. int err = lfs_dir_commit_(lfs, &cwd, &(lfs_entrylist_t){
  3102. {lfs_mktag(LFS_TYPE_REG | LFS_STRUCT_INLINE, file->id,
  3103. file->size), .u.buffer=file->cache.buffer},
  3104. file->attrs});
  3105. if (err) {
  3106. return err;
  3107. }
  3108. }
  3109. file->flags &= ~LFS_F_DIRTY;
  3110. }
  3111. return 0;
  3112. }
  3113. lfs_ssize_t lfs_file_read(lfs_t *lfs, lfs_file_t *file,
  3114. void *buffer, lfs_size_t size) {
  3115. uint8_t *data = buffer;
  3116. lfs_size_t nsize = size;
  3117. if ((file->flags & 3) == LFS_O_WRONLY) {
  3118. return LFS_ERR_BADF;
  3119. }
  3120. if (file->flags & LFS_F_WRITING) {
  3121. // flush out any writes
  3122. int err = lfs_file_flush(lfs, file);
  3123. if (err) {
  3124. return err;
  3125. }
  3126. }
  3127. if (file->pos >= file->size) {
  3128. // eof if past end
  3129. return 0;
  3130. }
  3131. size = lfs_min(size, file->size - file->pos);
  3132. nsize = size;
  3133. while (nsize > 0) {
  3134. // check if we need a new block
  3135. if (!(file->flags & LFS_F_READING) ||
  3136. file->off == lfs->cfg->block_size) {
  3137. if (!(file->flags & LFS_F_INLINE)) {
  3138. int err = lfs_ctz_find(lfs, &file->cache, NULL,
  3139. file->head, file->size,
  3140. file->pos, &file->block, &file->off);
  3141. if (err) {
  3142. return err;
  3143. }
  3144. } else {
  3145. file->block = 0xfffffffe;
  3146. file->off = file->pos;
  3147. }
  3148. file->flags |= LFS_F_READING;
  3149. }
  3150. // read as much as we can in current block
  3151. lfs_size_t diff = lfs_min(nsize, lfs->cfg->block_size - file->off);
  3152. int err = lfs_cache_read(lfs, &file->cache, NULL,
  3153. file->block, file->off, data, diff);
  3154. if (err) {
  3155. return err;
  3156. }
  3157. file->pos += diff;
  3158. file->off += diff;
  3159. data += diff;
  3160. nsize -= diff;
  3161. }
  3162. return size;
  3163. }
  3164. lfs_ssize_t lfs_file_write(lfs_t *lfs, lfs_file_t *file,
  3165. const void *buffer, lfs_size_t size) {
  3166. const uint8_t *data = buffer;
  3167. lfs_size_t nsize = size;
  3168. if ((file->flags & 3) == LFS_O_RDONLY) {
  3169. return LFS_ERR_BADF;
  3170. }
  3171. if (file->flags & LFS_F_READING) {
  3172. // drop any reads
  3173. int err = lfs_file_flush(lfs, file);
  3174. if (err) {
  3175. return err;
  3176. }
  3177. }
  3178. if ((file->flags & LFS_O_APPEND) && file->pos < file->size) {
  3179. file->pos = file->size;
  3180. }
  3181. if (!(file->flags & LFS_F_WRITING) && file->pos > file->size) {
  3182. // fill with zeros
  3183. lfs_off_t pos = file->pos;
  3184. file->pos = file->size;
  3185. while (file->pos < pos) {
  3186. lfs_ssize_t res = lfs_file_write(lfs, file, &(uint8_t){0}, 1);
  3187. if (res < 0) {
  3188. return res;
  3189. }
  3190. }
  3191. }
  3192. if ((file->flags & LFS_F_INLINE) &&
  3193. file->pos + nsize >= lfs->cfg->inline_size) {
  3194. // inline file doesn't fit anymore
  3195. file->block = 0xfffffffe;
  3196. file->off = file->pos;
  3197. lfs_alloc_ack(lfs);
  3198. int err = lfs_file_relocate(lfs, file);
  3199. if (err) {
  3200. file->flags |= LFS_F_ERRED;
  3201. return err;
  3202. }
  3203. file->flags &= ~LFS_F_INLINE;
  3204. file->flags |= LFS_F_WRITING;
  3205. }
  3206. while (nsize > 0) {
  3207. // check if we need a new block
  3208. if (!(file->flags & LFS_F_WRITING) ||
  3209. file->off == lfs->cfg->block_size) {
  3210. if (!(file->flags & LFS_F_INLINE)) {
  3211. if (!(file->flags & LFS_F_WRITING) && file->pos > 0) {
  3212. // find out which block we're extending from
  3213. int err = lfs_ctz_find(lfs, &file->cache, NULL,
  3214. file->head, file->size,
  3215. file->pos-1, &file->block, &file->off);
  3216. if (err) {
  3217. file->flags |= LFS_F_ERRED;
  3218. return err;
  3219. }
  3220. // mark cache as dirty since we may have read data into it
  3221. file->cache.block = 0xffffffff;
  3222. }
  3223. // extend file with new blocks
  3224. lfs_alloc_ack(lfs);
  3225. int err = lfs_ctz_extend(lfs, &lfs->rcache, &file->cache,
  3226. file->block, file->pos,
  3227. &file->block, &file->off);
  3228. if (err) {
  3229. file->flags |= LFS_F_ERRED;
  3230. return err;
  3231. }
  3232. } else {
  3233. file->block = 0xfffffffe;
  3234. file->off = file->pos;
  3235. }
  3236. file->flags |= LFS_F_WRITING;
  3237. }
  3238. // program as much as we can in current block
  3239. lfs_size_t diff = lfs_min(nsize, lfs->cfg->block_size - file->off);
  3240. while (true) {
  3241. int err = lfs_cache_prog(lfs, &file->cache, &lfs->rcache,
  3242. file->block, file->off, data, diff);
  3243. if (err) {
  3244. if (err == LFS_ERR_CORRUPT) {
  3245. goto relocate;
  3246. }
  3247. file->flags |= LFS_F_ERRED;
  3248. return err;
  3249. }
  3250. break;
  3251. relocate:
  3252. err = lfs_file_relocate(lfs, file);
  3253. if (err) {
  3254. file->flags |= LFS_F_ERRED;
  3255. return err;
  3256. }
  3257. }
  3258. file->pos += diff;
  3259. file->off += diff;
  3260. data += diff;
  3261. nsize -= diff;
  3262. lfs_alloc_ack(lfs);
  3263. }
  3264. file->flags &= ~LFS_F_ERRED;
  3265. return size;
  3266. }
  3267. lfs_soff_t lfs_file_seek(lfs_t *lfs, lfs_file_t *file,
  3268. lfs_soff_t off, int whence) {
  3269. // write out everything beforehand, may be noop if rdonly
  3270. int err = lfs_file_flush(lfs, file);
  3271. if (err) {
  3272. return err;
  3273. }
  3274. // update pos
  3275. if (whence == LFS_SEEK_SET) {
  3276. file->pos = off;
  3277. } else if (whence == LFS_SEEK_CUR) {
  3278. if (off < 0 && (lfs_off_t)-off > file->pos) {
  3279. return LFS_ERR_INVAL;
  3280. }
  3281. file->pos = file->pos + off;
  3282. } else if (whence == LFS_SEEK_END) {
  3283. if (off < 0 && (lfs_off_t)-off > file->size) {
  3284. return LFS_ERR_INVAL;
  3285. }
  3286. file->pos = file->size + off;
  3287. }
  3288. return file->pos;
  3289. }
  3290. int lfs_file_truncate(lfs_t *lfs, lfs_file_t *file, lfs_off_t size) {
  3291. if ((file->flags & 3) == LFS_O_RDONLY) {
  3292. return LFS_ERR_BADF;
  3293. }
  3294. lfs_off_t oldsize = lfs_file_size(lfs, file);
  3295. if (size < oldsize) {
  3296. // need to flush since directly changing metadata
  3297. int err = lfs_file_flush(lfs, file);
  3298. if (err) {
  3299. return err;
  3300. }
  3301. // lookup new head in ctz skip list
  3302. err = lfs_ctz_find(lfs, &file->cache, NULL,
  3303. file->head, file->size,
  3304. size, &file->head, &(lfs_off_t){0});
  3305. if (err) {
  3306. return err;
  3307. }
  3308. file->size = size;
  3309. file->flags |= LFS_F_DIRTY;
  3310. } else if (size > oldsize) {
  3311. lfs_off_t pos = file->pos;
  3312. // flush+seek if not already at end
  3313. if (file->pos != oldsize) {
  3314. int err = lfs_file_seek(lfs, file, 0, LFS_SEEK_END);
  3315. if (err < 0) {
  3316. return err;
  3317. }
  3318. }
  3319. // fill with zeros
  3320. while (file->pos < size) {
  3321. lfs_ssize_t res = lfs_file_write(lfs, file, &(uint8_t){0}, 1);
  3322. if (res < 0) {
  3323. return res;
  3324. }
  3325. }
  3326. // restore pos
  3327. int err = lfs_file_seek(lfs, file, pos, LFS_SEEK_SET);
  3328. if (err < 0) {
  3329. return err;
  3330. }
  3331. }
  3332. return 0;
  3333. }
  3334. lfs_soff_t lfs_file_tell(lfs_t *lfs, lfs_file_t *file) {
  3335. (void)lfs;
  3336. return file->pos;
  3337. }
  3338. int lfs_file_rewind(lfs_t *lfs, lfs_file_t *file) {
  3339. lfs_soff_t res = lfs_file_seek(lfs, file, 0, LFS_SEEK_SET);
  3340. if (res < 0) {
  3341. return res;
  3342. }
  3343. return 0;
  3344. }
  3345. lfs_soff_t lfs_file_size(lfs_t *lfs, lfs_file_t *file) {
  3346. (void)lfs;
  3347. if (file->flags & LFS_F_WRITING) {
  3348. return lfs_max(file->pos, file->size);
  3349. } else {
  3350. return file->size;
  3351. }
  3352. }
  3353. //int lfs_file_getattrs(lfs_t *lfs, lfs_file_t *file,
  3354. // const struct lfs_attr *attrs, int count) {
  3355. // // set to null in case we can't find the attrs (missing file?)
  3356. // for (int j = 0; j < count; j++) {
  3357. // memset(attrs[j].buffer, 0, attrs[j].size);
  3358. // }
  3359. //
  3360. // // load from disk if we haven't already been deleted
  3361. // if (!lfs_pairisnull(file->pair)) {
  3362. // lfs_dir_t cwd;
  3363. // int err = lfs_dir_fetch(lfs, &cwd, file->pair);
  3364. // if (err) {
  3365. // return err;
  3366. // }
  3367. //
  3368. // lfs_entry_t entry = {.off = file->pairoff};
  3369. // err = lfs_dir_get(lfs, &cwd, entry.off, &entry.d, 4);
  3370. // if (err) {
  3371. // return err;
  3372. // }
  3373. // entry.size = lfs_entry_size(&entry);
  3374. //
  3375. // err = lfs_dir_getattrs(lfs, &cwd, &entry, attrs, count);
  3376. // if (err) {
  3377. // return err;
  3378. // }
  3379. // }
  3380. //
  3381. // // override an attrs we have stored locally
  3382. // for (int i = 0; i < file->attrcount; i++) {
  3383. // for (int j = 0; j < count; j++) {
  3384. // if (attrs[j].type == file->attrs[i].type) {
  3385. // if (attrs[j].size < file->attrs[i].size) {
  3386. // return LFS_ERR_RANGE;
  3387. // }
  3388. //
  3389. // memset(attrs[j].buffer, 0, attrs[j].size);
  3390. // memcpy(attrs[j].buffer,
  3391. // file->attrs[i].buffer, file->attrs[i].size);
  3392. // }
  3393. // }
  3394. // }
  3395. //
  3396. // return 0;
  3397. //}
  3398. //int lfs_file_setattrs(lfs_t *lfs, lfs_file_t *file,
  3399. // const struct lfs_attr *attrs, int count) {
  3400. // if ((file->flags & 3) == LFS_O_RDONLY) {
  3401. // return LFS_ERR_BADF;
  3402. // }
  3403. //
  3404. // // at least make sure attributes fit
  3405. // if (!lfs_pairisnull(file->pair)) {
  3406. // lfs_dir_t cwd;
  3407. // int err = lfs_dir_fetch(lfs, &cwd, file->pair);
  3408. // if (err) {
  3409. // return err;
  3410. // }
  3411. //
  3412. // lfs_entry_t entry = {.off = file->pairoff};
  3413. // err = lfs_dir_get(lfs, &cwd, entry.off, &entry.d, 4);
  3414. // if (err) {
  3415. // return err;
  3416. // }
  3417. // entry.size = lfs_entry_size(&entry);
  3418. //
  3419. // lfs_ssize_t res = lfs_dir_checkattrs(lfs, &cwd, &entry, attrs, count);
  3420. // if (res < 0) {
  3421. // return res;
  3422. // }
  3423. // }
  3424. //
  3425. // // just tack to the file, will be written at sync time
  3426. // file->attrs = attrs;
  3427. // file->attrcount = count;
  3428. // file->flags |= LFS_F_DIRTY;
  3429. //
  3430. // return 0;
  3431. //}
  3432. /// General fs operations ///
  3433. int lfs_stat(lfs_t *lfs, const char *path, struct lfs_info *info) {
  3434. lfs_dir_t cwd;
  3435. int16_t id;
  3436. int err = lfs_dir_find(lfs, &cwd, &path, &id);
  3437. if (err) {
  3438. return err;
  3439. }
  3440. return lfs_dir_getinfo(lfs, &cwd, id, info);
  3441. }
  3442. int lfs_remove(lfs_t *lfs, const char *path) {
  3443. // deorphan if we haven't yet, needed at most once after poweron
  3444. if (!lfs->deorphaned) {
  3445. int err = lfs_deorphan(lfs);
  3446. if (err) {
  3447. return err;
  3448. }
  3449. }
  3450. lfs_dir_t cwd;
  3451. int err = lfs_dir_fetch(lfs, &cwd, lfs->root);
  3452. if (err) {
  3453. return err;
  3454. }
  3455. int16_t id;
  3456. err = lfs_dir_find(lfs, &cwd, &path, &id);
  3457. if (err) {
  3458. return err;
  3459. }
  3460. // grab entry to see if we're dealing with a dir
  3461. lfs_entry_t entry;
  3462. err = lfs_dir_getentry(lfs, &cwd, 0x701ff000,
  3463. lfs_mktag(LFS_TYPE_REG, id, 0), &entry);
  3464. if (err) {
  3465. return err;
  3466. }
  3467. if (lfs_tag_subtype(entry.tag) == LFS_TYPE_DIR) {
  3468. lfs_dir_t dir;
  3469. // must be empty before removal
  3470. err = lfs_dir_fetch(lfs, &dir, entry.u.pair);
  3471. if (err) {
  3472. return err;
  3473. }
  3474. if (dir.count > 0 || dir.split) {
  3475. return LFS_ERR_NOTEMPTY;
  3476. }
  3477. }
  3478. // delete the entry
  3479. err = lfs_dir_delete(lfs, &cwd, id);
  3480. if (err) {
  3481. return err;
  3482. }
  3483. // if we were a directory, find pred, replace tail
  3484. // TODO can this just deorphan?
  3485. if (lfs_tag_subtype(entry.tag) == LFS_TYPE_DIR) {
  3486. err = lfs_deorphan(lfs);
  3487. if (err) {
  3488. return err;
  3489. }
  3490. }
  3491. // if (lfs_tag_subtype(entry.tag) == LFS_TYPE_DIR) {
  3492. // int res = lfs_pred(lfs, dir.pair, &cwd);
  3493. // if (res < 0) {
  3494. // return res;
  3495. // }
  3496. //
  3497. // LFS_ASSERT(res); // must have pred
  3498. // cwd.tail[0] = dir.tail[0];
  3499. // cwd.tail[1] = dir.tail[1];
  3500. //
  3501. // err = lfs_dir_commit(lfs, &cwd, NULL, 0);
  3502. // if (err) {
  3503. // return err;
  3504. // }
  3505. // }
  3506. return 0;
  3507. }
  3508. int lfs_rename(lfs_t *lfs, const char *oldpath, const char *newpath) {
  3509. // deorphan if we haven't yet, needed at most once after poweron
  3510. if (!lfs->deorphaned) {
  3511. int err = lfs_deorphan(lfs);
  3512. if (err) {
  3513. return err;
  3514. }
  3515. }
  3516. // find old entry
  3517. lfs_dir_t oldcwd;
  3518. int16_t oldid;
  3519. int err = lfs_dir_find(lfs, &oldcwd, &oldpath, &oldid);
  3520. if (err) {
  3521. return err;
  3522. }
  3523. lfs_entry_t oldentry;
  3524. err = lfs_dir_getentry(lfs, &oldcwd, 0x701ff000,
  3525. lfs_mktag(LFS_TYPE_REG, oldid, 0), &oldentry);
  3526. if (err) {
  3527. return err;
  3528. }
  3529. // find new entry
  3530. lfs_dir_t newcwd;
  3531. int16_t newid;
  3532. err = lfs_dir_find(lfs, &newcwd, &newpath, &newid);
  3533. if (err && err != LFS_ERR_NOENT) {
  3534. return err;
  3535. }
  3536. bool prevexists = (err != LFS_ERR_NOENT);
  3537. bool samepair = (lfs_paircmp(oldcwd.pair, newcwd.pair) == 0);
  3538. lfs_entry_t preventry;
  3539. if (prevexists) {
  3540. // get prev entry, check that we have same type
  3541. err = lfs_dir_getentry(lfs, &newcwd, 0x701ff000,
  3542. lfs_mktag(LFS_TYPE_REG, newid, 0), &preventry);
  3543. if (err) {
  3544. return err;
  3545. }
  3546. if (lfs_tag_subtype(preventry.tag) != lfs_tag_subtype(oldentry.tag)) {
  3547. return LFS_ERR_ISDIR;
  3548. }
  3549. if (lfs_tag_subtype(preventry.tag) == LFS_TYPE_DIR) {
  3550. lfs_dir_t prevdir;
  3551. // must be empty before removal
  3552. err = lfs_dir_fetch(lfs, &prevdir, preventry.u.pair);
  3553. if (err) {
  3554. return err;
  3555. }
  3556. if (prevdir.count > 0 || prevdir.split) {
  3557. return LFS_ERR_NOTEMPTY;
  3558. }
  3559. }
  3560. } else {
  3561. // check that name fits
  3562. lfs_size_t nlen = strlen(newpath);
  3563. if (nlen > lfs->name_size) {
  3564. return LFS_ERR_NAMETOOLONG;
  3565. }
  3566. // get next id
  3567. err = lfs_dir_append(lfs, &newcwd, &newid);
  3568. if (err) {
  3569. return err;
  3570. }
  3571. }
  3572. // mark as moving
  3573. //printf("RENAME MOVE %d %d %d\n", oldcwd.pair[0], oldcwd.pair[1], oldid);
  3574. err = lfs_dir_commit_(lfs, &oldcwd, &(lfs_entrylist_t){
  3575. {lfs_mktag(LFS_TYPE_MOVE, oldid, 0)}});
  3576. if (err) {
  3577. return err;
  3578. }
  3579. if (samepair) {
  3580. // update pair if newcwd == oldcwd
  3581. newcwd = oldcwd;
  3582. }
  3583. // TODO check that all complaints are fixed
  3584. // // move to new location
  3585. // // TODO NAME?????
  3586. // // TODO HAH, move doesn't want to override things (due
  3587. // // to its use in compaction), but that's _exactly_ what we want here
  3588. // err = lfs_dir_commitwith(lfs, &newcwd, lfs_commit_move,
  3589. // &(struct lfs_commit_move){.dir=&oldcwd, .id={oldid, newid}});
  3590. // if (err) {
  3591. // return err;
  3592. // }
  3593. // // TODO NONONONONO
  3594. // // TODO also don't call strlen twice (see prev name check)
  3595. // err = lfs_dir_commit_(lfs, &newcwd, &(lfs_entrylist_t){
  3596. // {lfs_mktag(LFS_TYPE_NAME, newid, strlen(newpath)),
  3597. // .u.buffer=(void*)newpath}});
  3598. // if (err) {
  3599. // return err;
  3600. // }
  3601. err = lfs_dir_commit_(lfs, &newcwd, &(lfs_entrylist_t){
  3602. {lfs_mktag(LFS_TYPE_NAME, newid, strlen(newpath)),
  3603. .u.buffer=(void*)newpath}, &(lfs_entrylist_t){
  3604. {lfs_mktag(LFS_FROM_MOVE, newid, oldid),
  3605. .u.dir=&oldcwd}}});
  3606. if (err) {
  3607. return err;
  3608. }
  3609. if (samepair) {
  3610. // update pair if newcwd == oldcwd
  3611. oldcwd = newcwd;
  3612. }
  3613. // remove old entry
  3614. //printf("RENAME DELETE %d %d %d\n", oldcwd.pair[0], oldcwd.pair[1], oldid);
  3615. err = lfs_dir_delete(lfs, &oldcwd, oldid);
  3616. if (err) {
  3617. return err;
  3618. }
  3619. // if we were a directory, find pred, replace tail
  3620. // TODO can this just deorphan?
  3621. if (prevexists && lfs_tag_subtype(preventry.tag) == LFS_TYPE_DIR) {
  3622. err = lfs_deorphan(lfs);
  3623. if (err) {
  3624. return err;
  3625. }
  3626. }
  3627. return 0;
  3628. }
  3629. //int lfs_getattrs(lfs_t *lfs, const char *path,
  3630. // const struct lfs_attr *attrs, int count) {
  3631. // lfs_dir_t cwd;
  3632. // int err = lfs_dir_fetch(lfs, &cwd, lfs->root);
  3633. // if (err) {
  3634. // return err;
  3635. // }
  3636. //
  3637. // lfs_entry_t entry;
  3638. // err = lfs_dir_find(lfs, &cwd, &entry, &path);
  3639. // if (err) {
  3640. // return err;
  3641. // }
  3642. //
  3643. // return lfs_dir_getattrs(lfs, &cwd, &entry, attrs, count);
  3644. //}
  3645. //
  3646. //int lfs_setattrs(lfs_t *lfs, const char *path,
  3647. // const struct lfs_attr *attrs, int count) {
  3648. // lfs_dir_t cwd;
  3649. // int err = lfs_dir_fetch(lfs, &cwd, lfs->root);
  3650. // if (err) {
  3651. // return err;
  3652. // }
  3653. //
  3654. // lfs_entry_t entry;
  3655. // err = lfs_dir_find(lfs, &cwd, &entry, &path);
  3656. // if (err) {
  3657. // return err;
  3658. // }
  3659. //
  3660. // return lfs_dir_setattrs(lfs, &cwd, &entry, attrs, count);
  3661. //}
  3662. /// Filesystem operations ///
  3663. static int lfs_init(lfs_t *lfs, const struct lfs_config *cfg) {
  3664. lfs->cfg = cfg;
  3665. // setup read cache
  3666. lfs->rcache.block = 0xffffffff;
  3667. if (lfs->cfg->read_buffer) {
  3668. lfs->rcache.buffer = lfs->cfg->read_buffer;
  3669. } else {
  3670. lfs->rcache.buffer = lfs_malloc(lfs->cfg->read_size);
  3671. if (!lfs->rcache.buffer) {
  3672. return LFS_ERR_NOMEM;
  3673. }
  3674. }
  3675. // setup program cache
  3676. lfs->pcache.block = 0xffffffff;
  3677. if (lfs->cfg->prog_buffer) {
  3678. lfs->pcache.buffer = lfs->cfg->prog_buffer;
  3679. } else {
  3680. lfs->pcache.buffer = lfs_malloc(lfs->cfg->prog_size);
  3681. if (!lfs->pcache.buffer) {
  3682. return LFS_ERR_NOMEM;
  3683. }
  3684. }
  3685. // setup lookahead, round down to nearest 32-bits
  3686. LFS_ASSERT(lfs->cfg->lookahead % 32 == 0);
  3687. LFS_ASSERT(lfs->cfg->lookahead > 0);
  3688. if (lfs->cfg->lookahead_buffer) {
  3689. lfs->free.buffer = lfs->cfg->lookahead_buffer;
  3690. } else {
  3691. lfs->free.buffer = lfs_malloc(lfs->cfg->lookahead/8);
  3692. if (!lfs->free.buffer) {
  3693. return LFS_ERR_NOMEM;
  3694. }
  3695. }
  3696. // check that program and read sizes are multiples of the block size
  3697. LFS_ASSERT(lfs->cfg->prog_size % lfs->cfg->read_size == 0);
  3698. LFS_ASSERT(lfs->cfg->block_size % lfs->cfg->prog_size == 0);
  3699. // check that the block size is large enough to fit ctz pointers
  3700. LFS_ASSERT(4*lfs_npw2(0xffffffff / (lfs->cfg->block_size-2*4))
  3701. <= lfs->cfg->block_size);
  3702. // check that the size limits are sane
  3703. LFS_ASSERT(lfs->cfg->inline_size <= LFS_INLINE_MAX);
  3704. LFS_ASSERT(lfs->cfg->inline_size <= lfs->cfg->read_size);
  3705. lfs->inline_size = lfs->cfg->inline_size;
  3706. if (!lfs->inline_size) {
  3707. lfs->inline_size = lfs_min(LFS_INLINE_MAX, lfs->cfg->read_size);
  3708. }
  3709. LFS_ASSERT(lfs->cfg->attrs_size <= LFS_ATTRS_MAX);
  3710. lfs->attrs_size = lfs->cfg->attrs_size;
  3711. if (!lfs->attrs_size) {
  3712. lfs->attrs_size = LFS_ATTRS_MAX;
  3713. }
  3714. LFS_ASSERT(lfs->cfg->name_size <= LFS_NAME_MAX);
  3715. lfs->name_size = lfs->cfg->name_size;
  3716. if (!lfs->name_size) {
  3717. lfs->name_size = LFS_NAME_MAX;
  3718. }
  3719. // setup default state
  3720. lfs->root[0] = 0xffffffff;
  3721. lfs->root[1] = 0xffffffff;
  3722. lfs->files = NULL;
  3723. lfs->dirs = NULL;
  3724. lfs->deorphaned = false;
  3725. return 0;
  3726. }
  3727. static int lfs_deinit(lfs_t *lfs) {
  3728. // free allocated memory
  3729. if (!lfs->cfg->read_buffer) {
  3730. lfs_free(lfs->rcache.buffer);
  3731. }
  3732. if (!lfs->cfg->prog_buffer) {
  3733. lfs_free(lfs->pcache.buffer);
  3734. }
  3735. if (!lfs->cfg->lookahead_buffer) {
  3736. lfs_free(lfs->free.buffer);
  3737. }
  3738. return 0;
  3739. }
  3740. int lfs_format(lfs_t *lfs, const struct lfs_config *cfg) {
  3741. int err = lfs_init(lfs, cfg);
  3742. if (err) {
  3743. return err;
  3744. }
  3745. // create free lookahead
  3746. memset(lfs->free.buffer, 0, lfs->cfg->lookahead/8);
  3747. lfs->free.off = 0;
  3748. lfs->free.size = lfs_min(lfs->cfg->lookahead, lfs->cfg->block_count);
  3749. lfs->free.i = 0;
  3750. lfs_alloc_ack(lfs);
  3751. // create superblock dir
  3752. lfs_dir_t dir;
  3753. err = lfs_dir_alloc(lfs, &dir, false,
  3754. (const lfs_block_t[2]){0xffffffff, 0xffffffff});
  3755. if (err) {
  3756. return err;
  3757. }
  3758. // write root directory
  3759. lfs_dir_t root;
  3760. err = lfs_dir_alloc(lfs, &root, false,
  3761. (const lfs_block_t[2]){0xffffffff, 0xffffffff});
  3762. if (err) {
  3763. return err;
  3764. }
  3765. err = lfs_dir_commit_(lfs, &root, NULL);
  3766. if (err) {
  3767. return err;
  3768. }
  3769. lfs->root[0] = root.pair[0];
  3770. lfs->root[1] = root.pair[1];
  3771. dir.tail[0] = lfs->root[0];
  3772. dir.tail[1] = lfs->root[1];
  3773. // write one superblock
  3774. lfs_superblock_t superblock = {
  3775. .root[0] = lfs->root[0],
  3776. .root[1] = lfs->root[1],
  3777. .magic = {"littlefs"},
  3778. .version = LFS_DISK_VERSION,
  3779. .block_size = lfs->cfg->block_size,
  3780. .block_count = lfs->cfg->block_count,
  3781. .inline_size = lfs->inline_size,
  3782. .attrs_size = lfs->attrs_size,
  3783. .name_size = lfs->name_size,
  3784. };
  3785. dir.count += 1;
  3786. err = lfs_dir_commit_(lfs, &dir, &(lfs_entrylist_t){
  3787. {lfs_mktag(LFS_TYPE_SUPERBLOCK | LFS_STRUCT_DIR, 0,
  3788. sizeof(superblock)), .u.buffer=&superblock}});
  3789. if (err) {
  3790. return err;
  3791. }
  3792. // sanity check that fetch works
  3793. err = lfs_dir_fetch(lfs, &dir, (const lfs_block_t[2]){0, 1});
  3794. if (err) {
  3795. return err;
  3796. }
  3797. return lfs_deinit(lfs);
  3798. }
  3799. int lfs_mount(lfs_t *lfs, const struct lfs_config *cfg) {
  3800. int err = lfs_init(lfs, cfg);
  3801. if (err) {
  3802. return err;
  3803. }
  3804. // setup free lookahead
  3805. lfs->free.off = 0;
  3806. lfs->free.size = 0;
  3807. lfs->free.i = 0;
  3808. lfs_alloc_ack(lfs);
  3809. // load superblock
  3810. lfs_dir_t dir;
  3811. err = lfs_dir_fetch(lfs, &dir, (const lfs_block_t[2]){0, 1});
  3812. if (err) {
  3813. if (err == LFS_ERR_CORRUPT) {
  3814. LFS_ERROR("Invalid superblock at %d %d", 0, 1);
  3815. }
  3816. return err;
  3817. }
  3818. lfs_superblock_t superblock;
  3819. err = lfs_dir_getbuffer(lfs, &dir, 0x7ffff000, &(lfs_entry_t){
  3820. lfs_mktag(LFS_TYPE_SUPERBLOCK | LFS_STRUCT_DIR,
  3821. 0, sizeof(superblock)),
  3822. .u.buffer=&superblock});
  3823. if (err && err != LFS_ERR_RANGE) {
  3824. return err;
  3825. }
  3826. if (memcmp(superblock.magic, "littlefs", 8) != 0) {
  3827. LFS_ERROR("Invalid superblock at %d %d", 0, 1);
  3828. return LFS_ERR_CORRUPT;
  3829. }
  3830. uint16_t major_version = (0xffff & (superblock.version >> 16));
  3831. uint16_t minor_version = (0xffff & (superblock.version >> 0));
  3832. if ((major_version != LFS_DISK_VERSION_MAJOR ||
  3833. minor_version > LFS_DISK_VERSION_MINOR)) {
  3834. LFS_ERROR("Invalid version %d.%d", major_version, minor_version);
  3835. return LFS_ERR_INVAL;
  3836. }
  3837. if (superblock.inline_size) {
  3838. if (superblock.inline_size > lfs->inline_size) {
  3839. LFS_ERROR("Unsupported inline size (%d > %d)",
  3840. superblock.inline_size, lfs->inline_size);
  3841. return LFS_ERR_INVAL;
  3842. }
  3843. lfs->inline_size = superblock.inline_size;
  3844. }
  3845. if (superblock.attrs_size) {
  3846. if (superblock.attrs_size > lfs->attrs_size) {
  3847. LFS_ERROR("Unsupported attrs size (%d > %d)",
  3848. superblock.attrs_size, lfs->attrs_size);
  3849. return LFS_ERR_INVAL;
  3850. }
  3851. lfs->attrs_size = superblock.attrs_size;
  3852. }
  3853. if (superblock.name_size) {
  3854. if (superblock.name_size > lfs->name_size) {
  3855. LFS_ERROR("Unsupported name size (%d > %d)",
  3856. superblock.name_size, lfs->name_size);
  3857. return LFS_ERR_INVAL;
  3858. }
  3859. lfs->name_size = superblock.name_size;
  3860. }
  3861. lfs->root[0] = superblock.root[0];
  3862. lfs->root[1] = superblock.root[1];
  3863. return 0;
  3864. }
  3865. int lfs_unmount(lfs_t *lfs) {
  3866. return lfs_deinit(lfs);
  3867. }
  3868. /// Internal filesystem filesystem operations ///
  3869. int lfs_fs_traverse(lfs_t *lfs,
  3870. int (*cb)(lfs_t *lfs, void *data, lfs_block_t block), void *data) {
  3871. if (lfs_pairisnull(lfs->root)) {
  3872. return 0;
  3873. }
  3874. // iterate over metadata pairs
  3875. lfs_dir_t dir = {.tail = {0, 1}};
  3876. while (!lfs_pairisnull(dir.tail)) {
  3877. for (int i = 0; i < 2; i++) {
  3878. int err = cb(lfs, data, dir.tail[i]);
  3879. if (err) {
  3880. return err;
  3881. }
  3882. }
  3883. // iterate through ids in directory
  3884. int err = lfs_dir_fetch(lfs, &dir, dir.tail);
  3885. if (err) {
  3886. return err;
  3887. }
  3888. for (uint16_t id = 0; id < dir.count; id++) {
  3889. lfs_entry_t entry;
  3890. int err = lfs_dir_getentry(lfs, &dir, 0x701ff000,
  3891. lfs_mktag(LFS_TYPE_REG, id, 0), &entry);
  3892. if (err) {
  3893. if (err == LFS_ERR_NOENT) {
  3894. continue;
  3895. }
  3896. return err;
  3897. }
  3898. if (lfs_tag_struct(entry.tag) == LFS_STRUCT_CTZ) {
  3899. err = lfs_ctz_traverse(lfs, &lfs->rcache, NULL,
  3900. entry.u.ctz.head, entry.u.ctz.size, cb, data);
  3901. if (err) {
  3902. return err;
  3903. }
  3904. }
  3905. }
  3906. }
  3907. // iterate over any open files
  3908. for (lfs_file_t *f = lfs->files; f; f = f->next) {
  3909. if ((f->flags & LFS_F_DIRTY) && !(f->flags & LFS_F_INLINE)) {
  3910. int err = lfs_ctz_traverse(lfs, &lfs->rcache, &f->cache,
  3911. f->head, f->size, cb, data);
  3912. if (err) {
  3913. return err;
  3914. }
  3915. }
  3916. if ((f->flags & LFS_F_WRITING) && !(f->flags & LFS_F_INLINE)) {
  3917. int err = lfs_ctz_traverse(lfs, &lfs->rcache, &f->cache,
  3918. f->block, f->pos, cb, data);
  3919. if (err) {
  3920. return err;
  3921. }
  3922. }
  3923. }
  3924. return 0;
  3925. }
  3926. /*
  3927. int lfs_fs_traverse(lfs_t *lfs, int (*cb)(void*, lfs_block_t), void *data) {
  3928. if (lfs_pairisnull(lfs->root)) {
  3929. return 0;
  3930. }
  3931. // iterate over metadata pairs
  3932. lfs_block_t cwd[2] = {0, 1};
  3933. while (true) {
  3934. for (int i = 0; i < 2; i++) {
  3935. int err = cb(data, cwd[i]);
  3936. if (err) {
  3937. return err;
  3938. }
  3939. }
  3940. lfs_dir_t dir;
  3941. int err = lfs_dir_fetch(lfs, &dir, cwd);
  3942. if (err) {
  3943. return err;
  3944. }
  3945. // iterate over contents
  3946. lfs_entry_t entry;
  3947. while (dir.off + sizeof(entry.d) <= (0x7fffffff & dir.d.size)-4) {
  3948. err = lfs_dir_get(lfs, &dir,
  3949. dir.off, &entry.d, sizeof(entry.d));
  3950. lfs_entry_fromle32(&entry.d);
  3951. if (err) {
  3952. return err;
  3953. }
  3954. dir.off += lfs_entry_size(&entry);
  3955. if ((0x70 & entry.d.type) == LFS_STRUCT_CTZ) {
  3956. err = lfs_ctz_traverse(lfs, &lfs->rcache, NULL,
  3957. entry.d.u.file.head, entry.d.u.file.size, cb, data);
  3958. if (err) {
  3959. return err;
  3960. }
  3961. }
  3962. }
  3963. cwd[0] = dir.d.tail[0];
  3964. cwd[1] = dir.d.tail[1];
  3965. if (lfs_pairisnull(cwd)) {
  3966. break;
  3967. }
  3968. }
  3969. // iterate over any open files
  3970. for (lfs_file_t *f = lfs->files; f; f = f->next) {
  3971. if ((f->flags & LFS_F_DIRTY) && !(f->flags & LFS_F_INLINE)) {
  3972. int err = lfs_ctz_traverse(lfs, &lfs->rcache, &f->cache,
  3973. f->head, f->size, cb, data);
  3974. if (err) {
  3975. return err;
  3976. }
  3977. }
  3978. if ((f->flags & LFS_F_WRITING) && !(f->flags & LFS_F_INLINE)) {
  3979. int err = lfs_ctz_traverse(lfs, &lfs->rcache, &f->cache,
  3980. f->block, f->pos, cb, data);
  3981. if (err) {
  3982. return err;
  3983. }
  3984. }
  3985. }
  3986. return 0;
  3987. }
  3988. */
  3989. static int lfs_pred(lfs_t *lfs, const lfs_block_t pair[2], lfs_dir_t *pdir) {
  3990. // iterate over all directory directory entries
  3991. pdir->tail[0] = 0;
  3992. pdir->tail[1] = 1;
  3993. while (!lfs_pairisnull(pdir->tail)) {
  3994. if (lfs_paircmp(pdir->tail, pair) == 0) {
  3995. return true;
  3996. }
  3997. int err = lfs_dir_fetch(lfs, pdir, pdir->tail);
  3998. if (err) {
  3999. return err;
  4000. }
  4001. }
  4002. return false;
  4003. }
  4004. /*
  4005. static int lfs_pred(lfs_t *lfs, const lfs_block_t dir[2], lfs_dir_t *pdir) {
  4006. if (lfs_pairisnull(lfs->root)) {
  4007. return 0;
  4008. }
  4009. // iterate directories
  4010. int err = lfs_dir_fetch(lfs, pdir, (const lfs_block_t[2]){0, 1});
  4011. if (err) {
  4012. return err;
  4013. }
  4014. while (!lfs_pairisnull(pdir->d.tail)) {
  4015. if (lfs_paircmp(pdir->d.tail, dir) == 0) {
  4016. return true;
  4017. }
  4018. err = lfs_dir_fetch(lfs, pdir, pdir->d.tail);
  4019. if (err) {
  4020. return err;
  4021. }
  4022. }
  4023. return false;
  4024. }
  4025. */
  4026. static int lfs_parent(lfs_t *lfs, const lfs_block_t pair[2],
  4027. lfs_dir_t *parent, lfs_entry_t *entry) {
  4028. // iterate over all directory directory entries
  4029. parent->tail[0] = 0;
  4030. parent->tail[1] = 1;
  4031. while (!lfs_pairisnull(parent->tail)) {
  4032. int err = lfs_dir_fetch(lfs, parent, parent->tail);
  4033. if (err) {
  4034. return err;
  4035. }
  4036. // TODO make this O(n) by using fetchwith to match the pointers
  4037. for (uint16_t id = 0; id < parent->count; id++) {
  4038. int err = lfs_dir_getentry(lfs, parent, 0x43dff000,
  4039. lfs_mktag(LFS_STRUCT_DIR, id, 0), entry);
  4040. if (err) {
  4041. if (err == LFS_ERR_NOENT) {
  4042. continue;
  4043. }
  4044. return err;
  4045. }
  4046. if (lfs_paircmp(entry->u.pair, pair) == 0) {
  4047. return true;
  4048. }
  4049. }
  4050. }
  4051. return false;
  4052. }
  4053. /*
  4054. static int lfs_parent(lfs_t *lfs, const lfs_block_t dir[2],
  4055. lfs_dir_t *parent, lfs_entry_t *entry) {
  4056. if (lfs_pairisnull(lfs->root)) {
  4057. return 0;
  4058. }
  4059. parent->d.tail[0] = 0;
  4060. parent->d.tail[1] = 1;
  4061. // iterate over all directory directory entries
  4062. while (!lfs_pairisnull(parent->d.tail)) {
  4063. int err = lfs_dir_fetch(lfs, parent, parent->d.tail);
  4064. if (err) {
  4065. return err;
  4066. }
  4067. while (true) {
  4068. err = lfs_dir_next(lfs, parent, entry);
  4069. if (err && err != LFS_ERR_NOENT) {
  4070. return err;
  4071. }
  4072. if (err == LFS_ERR_NOENT) {
  4073. break;
  4074. }
  4075. if (((0x70 & entry->d.type) == LFS_STRUCT_DIR) &&
  4076. lfs_paircmp(entry->d.u.dir, dir) == 0) {
  4077. return true;
  4078. }
  4079. }
  4080. }
  4081. return false;
  4082. }
  4083. */
  4084. static int lfs_moved(lfs_t *lfs, lfs_dir_t *fromdir, uint16_t fromid) {
  4085. // grab entry pair we're looking for
  4086. fromdir->moveid = -1;
  4087. lfs_entry_t fromentry;
  4088. int err = lfs_dir_getentry(lfs, fromdir, 0x43dff000,
  4089. lfs_mktag(LFS_STRUCT_DIR, fromid, 0), &fromentry);
  4090. fromdir->moveid = fromid;
  4091. if (err) {
  4092. return err;
  4093. }
  4094. // skip superblock
  4095. lfs_dir_t todir;
  4096. err = lfs_dir_fetch(lfs, &todir, (const lfs_block_t[2]){0, 1});
  4097. if (err) {
  4098. return err;
  4099. }
  4100. // iterate over all directory directory entries
  4101. while (!lfs_pairisnull(todir.tail)) {
  4102. int err = lfs_dir_fetch(lfs, &todir, todir.tail);
  4103. if (err) {
  4104. return err;
  4105. }
  4106. for (int toid = 0; toid < todir.count; toid++) {
  4107. if (lfs_paircmp(todir.pair, fromdir->pair) == 0 &&
  4108. toid == fromid) {
  4109. continue;
  4110. }
  4111. lfs_entry_t toentry;
  4112. int err = lfs_dir_getentry(lfs, &todir, 0x43dff000,
  4113. lfs_mktag(LFS_STRUCT_DIR, toid, 0), &toentry);
  4114. if (err) {
  4115. if (err == LFS_ERR_NOENT) {
  4116. continue;
  4117. }
  4118. return err;
  4119. }
  4120. if (lfs_paircmp(toentry.u.pair, fromentry.u.pair) == 0) {
  4121. return true;
  4122. }
  4123. }
  4124. }
  4125. return false;
  4126. }
  4127. /*
  4128. static int lfs_moved(lfs_t *lfs, const void *e) {
  4129. if (lfs_pairisnull(lfs->root)) {
  4130. return 0;
  4131. }
  4132. // skip superblock
  4133. lfs_dir_t cwd;
  4134. int err = lfs_dir_fetch(lfs, &cwd, (const lfs_block_t[2]){0, 1});
  4135. if (err) {
  4136. return err;
  4137. }
  4138. // iterate over all directory directory entries
  4139. lfs_entry_t entry;
  4140. while (!lfs_pairisnull(cwd.d.tail)) {
  4141. err = lfs_dir_fetch(lfs, &cwd, cwd.d.tail);
  4142. if (err) {
  4143. return err;
  4144. }
  4145. while (true) {
  4146. err = lfs_dir_next(lfs, &cwd, &entry);
  4147. if (err && err != LFS_ERR_NOENT) {
  4148. return err;
  4149. }
  4150. if (err == LFS_ERR_NOENT) {
  4151. break;
  4152. }
  4153. if (!(LFS_STRUCT_MOVED & entry.d.type) &&
  4154. memcmp(&entry.d.u, e, sizeof(entry.d.u)) == 0) {
  4155. return true;
  4156. }
  4157. }
  4158. }
  4159. return false;
  4160. }
  4161. */
  4162. static int lfs_relocate(lfs_t *lfs,
  4163. const lfs_block_t oldpair[2], const lfs_block_t newpair[2]) {
  4164. // find parent
  4165. lfs_dir_t parent;
  4166. lfs_entry_t entry;
  4167. int res = lfs_parent(lfs, oldpair, &parent, &entry);
  4168. if (res < 0) {
  4169. return res;
  4170. }
  4171. if (res) {
  4172. // update disk, this creates a desync
  4173. entry.u.pair[0] = newpair[0];
  4174. entry.u.pair[1] = newpair[1];
  4175. int err = lfs_dir_commit_(lfs, &parent, &(lfs_entrylist_t){entry});
  4176. if (err) {
  4177. return err;
  4178. }
  4179. // update internal root
  4180. if (lfs_paircmp(oldpair, lfs->root) == 0) {
  4181. LFS_DEBUG("Relocating root %d %d", newpair[0], newpair[1]);
  4182. lfs->root[0] = newpair[0];
  4183. lfs->root[1] = newpair[1];
  4184. }
  4185. // clean up bad block, which should now be a desync
  4186. return lfs_deorphan(lfs);
  4187. }
  4188. // find pred
  4189. res = lfs_pred(lfs, oldpair, &parent);
  4190. if (res < 0) {
  4191. return res;
  4192. }
  4193. if (res) {
  4194. // just replace bad pair, no desync can occur
  4195. parent.tail[0] = newpair[0];
  4196. parent.tail[1] = newpair[1];
  4197. return lfs_dir_commit_(lfs, &parent, &(lfs_entrylist_t){
  4198. {lfs_mktag(LFS_TYPE_SOFTTAIL + parent.split*0x10, // TODO hm
  4199. 0x1ff, sizeof(lfs_block_t[2])),
  4200. .u.pair[0]=newpair[0], .u.pair[1]=newpair[1]}});
  4201. }
  4202. // couldn't find dir, must be new
  4203. return 0;
  4204. }
  4205. int lfs_deorphan(lfs_t *lfs) {
  4206. lfs->deorphaned = true;
  4207. if (lfs_pairisnull(lfs->root)) {
  4208. return 0;
  4209. }
  4210. lfs_dir_t pdir = {.split = true};
  4211. lfs_dir_t dir = {.tail = {0, 1}};
  4212. // iterate over all directory directory entries
  4213. while (!lfs_pairisnull(dir.tail)) {
  4214. int err = lfs_dir_fetch(lfs, &dir, dir.tail);
  4215. if (err) {
  4216. return err;
  4217. }
  4218. // check head blocks for orphans
  4219. if (!pdir.split) {
  4220. // check if we have a parent
  4221. lfs_dir_t parent;
  4222. lfs_entry_t entry;
  4223. int res = lfs_parent(lfs, pdir.tail, &parent, &entry);
  4224. if (res < 0) {
  4225. return res;
  4226. }
  4227. if (!res) {
  4228. // we are an orphan
  4229. LFS_DEBUG("Found orphan %d %d",
  4230. pdir.tail[0], pdir.tail[1]);
  4231. pdir.tail[0] = dir.tail[0];
  4232. pdir.tail[1] = dir.tail[1];
  4233. err = lfs_dir_commit_(lfs, &pdir, &(lfs_entrylist_t){
  4234. {lfs_mktag(LFS_TYPE_SOFTTAIL, 0x1ff,
  4235. sizeof(pdir.tail)), .u.buffer=pdir.tail}});
  4236. if (err) {
  4237. return err;
  4238. }
  4239. break;
  4240. }
  4241. if (!lfs_pairsync(entry.u.pair, pdir.tail)) {
  4242. // we have desynced
  4243. LFS_DEBUG("Found desync %d %d",
  4244. entry.u.pair[0], entry.u.pair[1]);
  4245. pdir.tail[0] = entry.u.pair[0];
  4246. pdir.tail[1] = entry.u.pair[1];
  4247. err = lfs_dir_commit_(lfs, &pdir, &(lfs_entrylist_t){
  4248. {lfs_mktag(LFS_TYPE_SOFTTAIL, 0x1ff,
  4249. sizeof(pdir.tail)), .u.buffer=pdir.tail}});
  4250. if (err) {
  4251. return err;
  4252. }
  4253. break;
  4254. }
  4255. }
  4256. // check entries for moves
  4257. if (dir.moveid >= 0) {
  4258. // TODO moves and stuff
  4259. // TODO need to load entry to find it
  4260. // // found moved entry
  4261. // int moved = lfs_moved(lfs, &entry.u);
  4262. // if (moved < 0) {
  4263. // return moved;
  4264. // }
  4265. //
  4266. // if (moved) {
  4267. // LFS_DEBUG("Found move %d %d",
  4268. // entry.d.u.dir[0], entry.d.u.dir[1]);
  4269. // err = lfs_dir_set(lfs, &dir, &entry, (struct lfs_region[]){
  4270. // {LFS_FROM_MEM, 0, entry.size, NULL, 0}}, 1);
  4271. // if (err) {
  4272. // return err;
  4273. // }
  4274. // } else {
  4275. // LFS_DEBUG("Found partial move %d %d",
  4276. // entry.d.u.dir[0], entry.d.u.dir[1]);
  4277. // entry.d.type &= ~LFS_STRUCT_MOVED;
  4278. // err = lfs_dir_set(lfs, &dir, &entry, (struct lfs_region[]){
  4279. // {LFS_FROM_MEM, 0, 1, &entry.d, 1}}, 1);
  4280. // if (err) {
  4281. // return err;
  4282. // }
  4283. // }
  4284. }
  4285. memcpy(&pdir, &dir, sizeof(pdir));
  4286. }
  4287. return 0;
  4288. }
  4289. /*
  4290. int lfs_deorphan(lfs_t *lfs) {
  4291. lfs->deorphaned = true;
  4292. if (lfs_pairisnull(lfs->root)) {
  4293. return 0;
  4294. }
  4295. lfs_dir_t pdir = {.d.size = 0x80000000};
  4296. lfs_dir_t cwd = {.d.tail[0] = 0, .d.tail[1] = 1};
  4297. // iterate over all directory directory entries
  4298. while (!lfs_pairisnull(cwd.d.tail)) {
  4299. int err = lfs_dir_fetch(lfs, &cwd, cwd.d.tail);
  4300. if (err) {
  4301. return err;
  4302. }
  4303. // check head blocks for orphans
  4304. if (!(0x80000000 & pdir.d.size)) {
  4305. // check if we have a parent
  4306. lfs_dir_t parent;
  4307. lfs_entry_t entry;
  4308. int res = lfs_parent(lfs, pdir.d.tail, &parent, &entry);
  4309. if (res < 0) {
  4310. return res;
  4311. }
  4312. if (!res) {
  4313. // we are an orphan
  4314. LFS_DEBUG("Found orphan %d %d",
  4315. pdir.d.tail[0], pdir.d.tail[1]);
  4316. pdir.d.tail[0] = cwd.d.tail[0];
  4317. pdir.d.tail[1] = cwd.d.tail[1];
  4318. err = lfs_dir_commit(lfs, &pdir, NULL, 0);
  4319. if (err) {
  4320. return err;
  4321. }
  4322. break;
  4323. }
  4324. if (!lfs_pairsync(entry.d.u.dir, pdir.d.tail)) {
  4325. // we have desynced
  4326. LFS_DEBUG("Found desync %d %d",
  4327. entry.d.u.dir[0], entry.d.u.dir[1]);
  4328. pdir.d.tail[0] = entry.d.u.dir[0];
  4329. pdir.d.tail[1] = entry.d.u.dir[1];
  4330. err = lfs_dir_commit(lfs, &pdir, NULL, 0);
  4331. if (err) {
  4332. return err;
  4333. }
  4334. break;
  4335. }
  4336. }
  4337. // check entries for moves
  4338. lfs_entry_t entry;
  4339. while (true) {
  4340. err = lfs_dir_next(lfs, &cwd, &entry);
  4341. if (err && err != LFS_ERR_NOENT) {
  4342. return err;
  4343. }
  4344. if (err == LFS_ERR_NOENT) {
  4345. break;
  4346. }
  4347. // found moved entry
  4348. if (entry.d.type & LFS_STRUCT_MOVED) {
  4349. int moved = lfs_moved(lfs, &entry.d.u);
  4350. if (moved < 0) {
  4351. return moved;
  4352. }
  4353. if (moved) {
  4354. LFS_DEBUG("Found move %d %d",
  4355. entry.d.u.dir[0], entry.d.u.dir[1]);
  4356. err = lfs_dir_set(lfs, &cwd, &entry, (struct lfs_region[]){
  4357. {LFS_FROM_MEM, 0, entry.size, NULL, 0}}, 1);
  4358. if (err) {
  4359. return err;
  4360. }
  4361. } else {
  4362. LFS_DEBUG("Found partial move %d %d",
  4363. entry.d.u.dir[0], entry.d.u.dir[1]);
  4364. entry.d.type &= ~LFS_STRUCT_MOVED;
  4365. err = lfs_dir_set(lfs, &cwd, &entry, (struct lfs_region[]){
  4366. {LFS_FROM_MEM, 0, 1, &entry.d, 1}}, 1);
  4367. if (err) {
  4368. return err;
  4369. }
  4370. }
  4371. }
  4372. }
  4373. memcpy(&pdir, &cwd, sizeof(pdir));
  4374. }
  4375. return 0;
  4376. }
  4377. */
  4378. /// External filesystem filesystem operations ///
  4379. //int lfs_fs_getattrs(lfs_t *lfs, const struct lfs_attr *attrs, int count) {
  4380. // lfs_dir_t dir;
  4381. // int err = lfs_dir_fetch(lfs, &dir, (const lfs_block_t[2]){0, 1});
  4382. // if (err) {
  4383. // return err;
  4384. // }
  4385. //
  4386. // lfs_entry_t entry = {.off = sizeof(dir.d)};
  4387. // err = lfs_dir_get(lfs, &dir, entry.off, &entry.d, 4);
  4388. // if (err) {
  4389. // return err;
  4390. // }
  4391. // entry.size = lfs_entry_size(&entry);
  4392. //
  4393. // if (err != LFS_ERR_NOENT) {
  4394. // if (!err) {
  4395. // break;
  4396. // }
  4397. // return err;
  4398. // }
  4399. //
  4400. // lfs_dir_t cwd;
  4401. // int err = lfs_dir_fetch(lfs, &cwd, lfs->root);
  4402. // if (err) {
  4403. // return err;
  4404. // }
  4405. //
  4406. // lfs_entry_t entry;
  4407. // err = lfs_dir_find(lfs, &cwd, &entry, &path);
  4408. // if (err) {
  4409. // return err;
  4410. // }
  4411. //
  4412. // return lfs_dir_getinfo(lfs, &cwd, &entry, info);
  4413. // return lfs_dir_getattrs(lfs, &dir, &entry, attrs, count);
  4414. //}
  4415. //
  4416. //int lfs_fs_setattrs(lfs_t *lfs, const struct lfs_attr *attrs, int count) {
  4417. // lfs_dir_t dir;
  4418. // int err = lfs_dir_fetch(lfs, &dir, (const lfs_block_t[2]){0, 1});
  4419. // if (err) {
  4420. // return err;
  4421. // }
  4422. //
  4423. // lfs_entry_t entry = {.off = sizeof(dir.d)};
  4424. // err = lfs_dir_get(lfs, &dir, entry.off, &entry.d, 4);
  4425. // if (err) {
  4426. // return err;
  4427. // }
  4428. // entry.size = lfs_entry_size(&entry);
  4429. //
  4430. // return lfs_dir_setattrs(lfs, &dir, &entry, attrs, count);
  4431. //}
  4432. static int lfs_fs_size_count(void *p, lfs_block_t block) {
  4433. lfs_size_t *size = p;
  4434. *size += 1;
  4435. return 0;
  4436. }
  4437. lfs_ssize_t lfs_fs_size(lfs_t *lfs) {
  4438. lfs_size_t size = 0;
  4439. int err = lfs_fs_traverse(lfs, lfs_fs_size_count, &size);
  4440. if (err) {
  4441. return err;
  4442. }
  4443. return size;
  4444. }