^c5ddlZddlZddlmZmZmZmZddlmZddl m Z ddl m Z m Z mZmZmZddlmZddlmZmZmZmZmZmZd Zd Zdd Zd Zd ZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dS)N)binhexsha1nodeconstantsshort)_)open)errorfileloglockpycompatrevlog)hashutil) constantsdatapackfileserverclient historypackrepack shallowutilc |d}t||\}}}|td|z|td|z|tdt |z|td|tddz|g}|r|d}||\} } } } |td t |t | t | t | | fz| t jkr|| | t jkr|| |dSdS) N decompressssize: %d bytes s path: %s s key: %s  s%12s => %12s %13s %13s %12s )snodesp1sp2slinknodescopyfromrs%s => %s %s %s %s ) get parsefileblobstatusrrpoprnullidappend) uipathoptsrsize firstnodemappingqueuenodep1p2linknodecopyfroms C/usr/lib/python3/dist-packages/hgext/remotefilelog/debugcommands.pydebugremotefilelogr,%s,''J,T:>>D)WIIa#$$t+,,,IIa$&'''IIa % "2"23444IIahhII *++ ; < KE  yy||%,T]"B( ' ( (T{{E"IIuRyy%//8L M    ") ) ) LL    ") ) ) LL         c nttj|}tj|jd|}g}t j|D]=}d|vr7|| |t|>t|d}| d}tj |rt j|tj|jd}Gdd }|} |D]} | |vr| | } i} | rG| d | d <t| d | d <|| | | | | d | d |S)Ns store/datas_old)fileidc*|SN)linkrev)xs r+z!buildtemprevlog..Ls r-)keysdata/temprevlog.is temprevlogceZdZdZdS)buildtemprevlog..faketcdSr1)selfabcs r+addz"buildtemprevlog..faket.addUs Dr-N)__name__ __module__ __qualname__r>r9r-r+faketr7Ts#     r-rBrscopyrscopyrev)rrsha1digestosr joinlistdirrfilectxrsortedsjoinexistsremover svfsr&parentsfilenoderenamedr>datar2) repofilefilekeyfiledirfctxsrOtemppathrrBtfctxpmetas r+buildtemprevlogr]As(-%%,,..//Ggll49mW==G EJw''CC ( " " LLd3x==AA B B B 533 4 4 4Ezz.//H w~~h ( =11A A @ @ 99;;d " "  LLNN " "4==?? 3 3 <<>> 6 LLNN1-DM"4<<>>!#455D  diikk4DLLNNAaD!A$???? Hr-c |dsS|ds>|ds)tj|r||s ||||fi|St ||}|dd}|dvr$t jtd|z|jtj z}|rd}nd }|dkr| d |zd zn!|d kr| d |zdz|D]} | | } |r| | } n|| } |dkr || } n#t $r|j|jg} YnwxYw| d| || || | || t+| t+| dt+| d fz|d kr|| } | d| || || || || | || | d| d t+| f zdS)z"dump the contents of an index file changelogmanifestdirsformatr)rrsunknown format %ds deltas bases rev offset length s& linkrev nodeid p1 p2 rs' rev flag offset length size s# link p1 p2 nodeid s"% 6d % 9d % 7d % 6d % 7d %s %s %s s0% 6d %04x % 8d % 8d % 8d % 6d % 6d % 6d % 6d %s N)rr isenabled shallowmatchr]r Abortrversionr FLAG_GENERALDELTAwriter& deltaparent chainbaserN Exceptionrstartlengthr2r parentrevsflagsrawsize)origrrRfile_r!rXformat generaldeltabasehdrir&baseppprs r+ debugindexryhs - 88J  - 88E??-$T** -   '' -tBe,,t,,,e$$AXXi # #F Vk!011F:;;;9v77L {{ ,w6:33    1  '(+##   ((vvayy  "==##DD;;q>>D Q;; 0YYt__ 0 0 0k4;/ 0 HH6GGAJJHHQKKIIaLL$KK"Q%LL"Q%LL      q[[aB HHDGGAJJGGAJJHHQKKIIaLLIIaLLqEqE$KK     5((s.FFFcRtj|s ||||St|tj|dd}|d|D]}||}||}| d| |d|fz|d|j kr3| d| |d|fz| ddS)z(dump an index DAG as a graphviz dot fileNs digraph G { s %d -> %d rrs} ) rrbr]rEr basename writenoi18nr&rNrgrevr)rprrRrqrXrur&rws r+ debugindexdotrs   & &%tBe$$$bg..u55crc:;;ANN#$$$ ::vvayy YYt__ AEE"Q%LL!#44555 a5DK   HH_be a'88 9 9 9HHVr-c |d}tj|D]\}}}|D]}|dkr tj||}t ||\} } } | D]\} } }}|tjkrntj ||}tj d||}| d|tj ||fz،dS)Nrsrepossreponames%s %s ) rrEwalkr rFrvaluesrrrelpathr getcachekeyr)rr r!rrootdirsfilesrSfilepathr"r#r$r'r(r)r* actualpathr5s r+verifyremotefilelogrs",''JWT]]dE  Dxw||D$//H'4Xz'J'J $D)W.5nn.>.>  *B(0777!#t!.printtotalss'!  &7J$Z(=8)A~~9(H NN(IIa'kC NN:;;^+22266]*11!44      r-sBad entry: %s appears twice rs (empty name)s %s%s%s%s Node Delta Base Delta Lengths Blob Sizers (missing)s %s %s %s%s rs %d failures )rrgrr getdeltachainrdumpdeltachainrrset iterentriesr>rgetmetar METAKEYSIZEr bytestr _sanitycheckwarn)rpathsr!r dpackr& deltachain hashformatterrbasesnodesfailuresfilename deltabasedeltalennamer\blobsizerrrrs` @@@@r+ debugdatapackrsl]] t  .$**X.../D D!!!!$''xx  ,,S#d))<base): - Each deltabase must itself be a node elsewhere in the pack - There must be no cycles rs,Bad entry: %s has an unknown deltabase (%s) rs"Bad entry: %s has a cycle (at %s) )rrrrrr>)rrrrr&seencurrentrs r+rrgsH//uu'N ,333%%H ;;i(8(89: A D  > ;;i(8(89: A G HHW   gI/,3334(.d Or-c t}d}d}|D]\}}}}} ||kr|d|z|}|dd|d|d|ddfz|d ||||ttj| t | fzdS) Nr %s s%s %s %s %s rrs Delta SHA1rs%s %s %s %d )rrgrrrCrDr) rrr!rrrrr& deltabasenodedeltas r+rrs/MGL:D  6$- | # # HHY) * * *#L   g&&##G,,##G,,%%a((        d## m,,HM%((//1122E        r-c hd|vr|d|d}tj|}d}|D]}|\}}}}} } ||kr|d|z|dddddddddd fz|}|d t |t |t |t | | fzdS) Ns.histrs %s%s%s%s%s rrsP1 NodesP2 Nodes Link Nodes Copy Froms%s %s %s %s %s )rrrrgrr) rr hpackrentryrr&p1nodep2noder)r*s r+debughistorypackrsU4*djj***+  #D ) )EL""$$  =B:$( | # # HHY) * * * HHMM"%%$$R(($$R(( &&r**    $L  #d f f h     r-ctjtj|dd5 ddddS#1swxYwYdS)Ns repacklock)timeout)lockmodr r repacklockvfsrRs r+debugwaitonrepackrs f*400- L L Ls 9==c ||jddddtd|jz5 ddddS#1swxYwYdS)Ns prefetchlockTsprefetching in %s)_lockrMrorigrootrs r+debugwaitonprefetchrs      $-/                        sAA Ar1)(rErmercurial.noderrrrmercurial.i18nrmercurial.pycompatr mercurialr r r rr r mercurial.utilsrrrrrrrr,r]ryrrrrrrrrrrr9r-r+rs  ######%$$$$$8$ $ $ NPPPPf"(   $$$D^^^B)))X   <   B      r-