5wY<ddlZddlmZddlmZddlmZmZmZm Z m Z m Z m Z ddl mZe jZe j ZdZejZdZd Zd Zd Zej/e d d ZdZy)N)_)open)error exthelperhttppeerutilwireprototypeswireprotov1peerwireprotov1server)lfutilsa This repository uses the largefiles extension. Please enable it in your Mercurial config file. c*|j5}tj||}tjt j j|tj||jj} |jD]}|j||jjd|tj|jk7rt!dt#d|j%tj&|| |j5 dddt/j0dr|j3SdS#t $r~}|j(j+t#d||j,fzt/j0d|r|j3ndcYd}~|j5cdddSd}~wwxYw#|j5wxYw#1swYxYw)zcServer command for putting a largefile into a repository's local store and into the user cache.) createmoders$largefile contents do not match hashs,largefiles: failed to put %s into store: %s r N)mayberedirectstdior storepathrmakedirsospathdirnameatomictempfilestorer getpayloadwrite_fpseekhexsha1IOErrorrcloselinktousercacheuiwarnstrerrorr pushresgetvaluediscard)repoprotoshaoutputrtmpfppes :usr/lib/python3.12/site-packages/hgext/largefiles/proto.pyputlfiler/#s  ! ! #vc* bggood+,##DTZZ5J5JK %%' A( IINN1 fnnUYY//a#J!KLL KKM  " "4 - MMO- $0  ! !!&V__%6 JJc JJ  GGLLBC #$ "))6??$C  MMO- $ #  MMO- $ #sPA4H BE*%H * G13AG, G1G4H ,G11G44HH  Hctj||}|s!tjt d|zt |dt jjdfd}tj|S)z\Server command for retrieving a largefile from the repository-local cache or user cache.s+requested largefile %s not present in cachesrbc3XKdztjD]}|yw)Ns%d )r filechunkiter)chunkflengths r. generatorzgetlfile..generatorQs,''*EK+s'*)gen) r findfilerAbortrrrfstatfilenor streamreslegacy)r'r(r)filenamer7r5r6s @@r.getlfiler?AsxtS)H kk < = C   XuA XXahhj !! $F  ) )ik ::rctj||}|stjdStjdS)a;Server command for checking if a largefile is present - returns '2 ' if the largefile is missing, '0 ' if it seems to be in good condition. The value 1 is reserved for mismatched checksum, but that is too expensive to be verified on every stat and must be caught be running 'hg verify' server side.s2 s0 )r r9r bytesresponse)r'r(r)r>s r. statlfilerBYs9tS)H ++F33  ' ' //rcZ|jGfdd|j}||_y)NcleZdZfdZej dZdZdZej dZ y)+wirereposetup..lfileswirerepositoryc}|jdr*|jGfdd|j}||_|S)Ns largefilesceZdZfdZy)Wwirereposetup..lfileswirerepository.commandexecutor..lfscommandexecutorc$|dk(rd}||S)Nsheadsslheads)selfcommandargsorig_callcommands r. callcommandzcwirereposetup..lfileswirerepository.commandexecutor..lfscommandexecutor.callcommandps"h.&/G/>>rN)__name__ __module__ __qualname__rO)rNsr.lfscommandexecutorrHos?rrS)capablerO __class__)rKexecutorrSrNorig_commandexecutors @r.commandexecutorz;wirereposetup..lfileswirerepository.commandexecutorjsD+-H||M*#+#7#7 ?););? &8"Orc8|jj|S)N)heads batchable)rKs r.lheadsz2wirereposetup..lfileswirerepository.lheadsxs::''- -rct|jtjrs|jd||ddi} |j dd\}}|j dD]'}|j jtd|)t|S |jd|| \}}|d k(rtjtd |t|S#t$r*|j jtd |zYywxYw#t$rYyt$r tjtd wxYw)Nsputlfilez content-typezapplication/mercurial-0.1)datar)headers r Tsremote: s!unexpected putlfile response: %r r)rsputlfile failed:s&putlfile failed (unexpected response):) issubclassrUr_callsplit splitlinesr!r"rint ValueError _callpushr ResponseErrorr)rKr)fdresdr*lrets r.r/z4wirereposetup..lfileswirerepository.putlfile|s?$..(*;*;<jj+-HI !  # % 3IAv#..t4 Q{^Q75q6M "&..bc."JKCcz#1112Fs8O"GGLL#H!IC!OP!--CDcs%ACAD0DD E (Ec3K|jd|}|j} t|}tj||D]}|t|jtjrC|jd}|r/|j t j td|yyy#t$r1|j t j td|YwxYww)z.lfileswirerepository.getlfiles%%ks%;F__&F V++F&A B$..(*;*;< AKK++A.E,FN=  ''*A(BFK s($C7 B:BC7:7C41C73C44C7cd}d|i}||fS)NcX t|S#ttjf$rYywxYw)N)rfrgurlerr httperror)rls r.decodezEwirereposetup..lfileswirerepository.statlfile..decodes/q6M"F$4$45  s ))ssharJ)rKr)r{results r.rBz5wirereposetup..lfileswirerepository.statlfiles c]F6> !rN) rPrQrRrXr r[r\r/r?rB)rWsr.lfileswirerepositoryrEisG   " " . # .# J .  " " " # "rr})rXrU)r!r'r}rWs @r. wirereposetupr~fs+//\"t~~\"|*DNrs _capabilitiesc:|||}|jd|S)z$announce largefile server capabilityslargefiles=serve)append)origr'r(capss r. _capabilitiesrs" e DKK#$ Krcptj|rtjtS|||S)zTWrap server command - largefile capable clients will know to call lheads instead)r islfilesrepor ooberrorLARGEFILES_REQUIRED_MSG)rr'r(s r.rZrZs14 &&'>?? e r)rmercurial.i18nrmercurial.pycompatr mercurialrrrrr r r r ryurlreqrehr/r?rBr~ wrapfunctionrrZrJrr.rs  #   YK<;0 0a*J"$456r