|=UBddlZddlmZmZddlmZddlmZddlm Z m Z m Z dZ eje ZdZd ZejeZd Zd Zd Zd ZdZdZdZdZdZd ZGdde j8ZGdde jZGdde j>Z y)N)hexsha1nodeconstants)util)hashutil)basepack constants shallowutils!20sQQIIs!20sQs!20s20s20s20sHRs.histidxs .histpackc.eZdZeZeZdZddZdZdZy)historypackstorect|SN) historypack)selfpaths Cusr/lib/python3.12/site-packages/hgext/remotefilelog/historypack.pygetpackzhistorypackstore.getpack-s 4  Nc|jD]} |j|||cS|jD]} |j|||cSt||f#t$rY^wxYw#t$rYBwxYw)Nknown)packs getancestorsKeyErrorrefresh)rnamenoderpacks rrzhistorypackstore.getancestors0sJJD ((t5(AA LLND ((t5(AA# d|$$     s"A A/ A,+A,/ A;:A;c|jD]} |j||cS|jD]} |j||cSt||f#t$rYZwxYw#t$rY@wxYwr)r getnodeinforr )rr!r"r#s rr%zhistorypackstore.getnodeinfo?sJJD ''d33 LLND ''d33# d|$$     s"AA+ A('A(+ A76A7c4td|t|fz)Ns&cannot add to historypackstore (%s:%s) RuntimeErrorrrfilenamer"p1p2linknodecopyfroms raddzhistorypackstore.addNs  53t98M M  rr) __name__ __module__ __qualname__ INDEXSUFFIX PACKSUFFIXrrr%r/rrrr)s KJ! % % rrceZdZeZeZdgZfdZdZddZdZ ddZ dZ dZ d Z d Zd Zdd Zd ZdZdZxZS)rrcXtt| |t|_t |_yr)superr__init__ INDEXFORMAT2 INDEXFORMATINDEXENTRYLENGTH2INDEXENTRYLENGTH)rr __class__s rr9zhistorypack.__init__Zs" k4)$/' 1rcg}|D]\}} |j|||S#t$r|j||fY;wxYwr) _findnoderappend)rkeysmissingr!r"s r getmissingzhistorypack.getmissing_sPJD$ -tT*  -d|, -s"AAc|r||vrgS|j|||}i}|D]\}}}} } ||| | f||<|s t||f|S)zReturns as many ancestors as we're aware of. return value: { node: (p1, p2, linknode, copyfrom), ... } r) _getancestorsr) rr!r"r ancestorsresultsancnoder+r,r-r.s rrzhistorypack.getancestorsiso TU]I&&tT&? 3< /GRXx "B(;GG 4=D$<( (rc,|j||ddS)Nr)r@)rr!r"s rr%zhistorypack.getnodeinfo}s~~dD)!"--rc#K| t}|j|}|\}}}}} |h} d} | |kr| sy|j|| z\} } | tz } | r| t | z } | t }|| vr| j || t}| t}|tjk7r||vr| j||tjk7r||vr| j||||| t| f| |kryywNr) set _findsection _readentryPACKENTRYLENGTHlenANC_NODEremove ANC_P1NODE ANC_P2NODErnullidr/ ANC_LINKNODE)rr!r"rsectionr*offsetsizenodeindexoffset nodeindexsizependingoentryr.rIp1nodep2nodes rrFzhistorypack._getancestorss =EE##D)AH>&$& $h"oofqj9OE8  AS]"HoG'!w'z*z*.555&:MKK'.555&:MKK'l0CXNN%$hs C8C=;C=c|j}tjt|||tz}d}|t }|dk7r|tz }||||z}||fSrL)_datastructunpack PACKFORMATrP ANC_COPYFROM)rrYdatar_r. copyfromlens rrOzhistorypack._readentryshzz Vf&>? L) !  o %FFVk%9:Hhrc4td|t|fz)Ns!cannot add to historypack (%s:%s)r'r)s rr/zhistorypack.adds  0Hc$i3H H  rc|jdk(r.|j||}|D]\}}}}}||k(s|||||fcSnp|j|} | dd\} } |j|| | | zt} | :t j t| \}} |j| \} }| dd|fzStd|t|fz)Nrrr s unable to find history for %s:%s) VERSIONrFrN_bisectNODEINDEXENTRYLENGTHrdreNODEINDEXFORMATrOrr)rr!r"rGrIr`rar-r.rXr[r\r_rYs rr@zhistorypack._findnodes <<1 **46I?H;8d?#VVXxHH@I''-G-4QR[ *O]LL-/$ E  %}}_eD f"&//&"9xRayH;..:dCI=NNOOrcf|j}tj|j}t j |j |d|jd}|j}|||jz}|j}t|dz|jD]}|||jz} | |k7sn|} |j||| |j} | s t|t j |j | } | \} } }}}|j"||t$j&z}t j d|d}|t$j&z }|j"|||z}||k7rtd||fz||z }t j d|j(| | t$j&zd}| t$j&z } |j(| | |z}| |z } ||k7rtd||fz| t*z } | }|t$j&z |z t*z }|||||fS)Nrr!Hs&found file name %s when looking for %s)paramsrsha1digestrdre fanoutstruct fanoutprefix _fanouttable indexstart _indexendrange fanoutcountrmr=rr;_indexr FILENAMESIZErcENTRYCOUNTSIZE)rr!rrnamehash fanoutkeyfanoutstartindexendiendr_rawentryxrYrZr[r\ rawnamelen actualnamelen actualnamefilenamelengthnodelistoffset nodelistsizes rrNzhistorypack._findsectionsc==&--/MM   *?F,?,?!@  ""y!F$5$55>>y1}f&8&89A)f///Ce|: C Xuc43H3HI4. ==!1!159:B764-[[ o 0F0FF  eZ8; 9111[[ o =   9ZEG^C#.(rc>|D]\}}|j|||yr)markhistoryentry)rledgeroptionsr*r"s r markledgerzhistorypack.markledgers""NHd  # #D(D 9#rc|jj|g}t|}|Dchc]'}|js|j|j f)}}t ||z dk(r\|j|jvrCtj|jdtj|jdyyycc}w)NrT) ignoremissing) sourcesgetrMhistoryrepackedr*r"rQrcreatedr unlinkpath indexpathpackpath)rrentriesallkeyse repackedkeyss rcleanupzhistorypack.cleanup#s..$$T2.d)*1 *1QQ5F5FQZZ '   w% &! +yy.dC TB/ ,  s CCc#PK|jD]\}}}}}}||fywr) iterentries)rfnrs r__iter__zhistorypack.__iter__/s/ $ 0 0 2 Aq!Q1Q$J!3s$&c#Kd}||jkr>|j}tjd|||tj zd}|tj z }||||z}||z }tjd|||t zd}|t z }t|D]}tjt|||tz}|tz }||||tz}||tz }||t|t|t|t|f|xjtz c_|j!||jkr=yyw)Nrrqr!I)datasizercrdrer r}r~rzrfrPrgrRrTrUrW_pagedin freememory) rrYrh filenamelenr*revcountrr_r.s rrzhistorypack.iterentries3sgt}}$::D --tFVi.D.D%DEK i,, ,FFVk%9:H k !F}}tFVn%<=H n $F8_ Vf.F G/)% 2E)EF% --(O*%*%,'  0 %%* OO It}}$s EEEr)r0r1r2r3r4SUPPORTED_VERSIONSr9rDrr%rFrOr/r@rNrmrrrr __classcell__r>s@rrrTs`KJ2 (. O6  P0@ D.: C'rrcPeZdZdZeZeZdgZdfd ZdZdZ d fd Z dZ xZ S) mutablehistorypacka A class for constructing and serializing a histpack file and index. A history pack is a pair of files that contain the revision history for various file revisions in Mercurial. It contains only revision history (like parent pointers and linknodes), not any revision content information. It consists of two files, with the following format: .histpack The pack itself is a series of file revisions with some basic header information on each. datapack = [,...] filesection = [,...] revision = The revisions within each filesection are stored in topological order (newest first). If a given entry has a parent from another file (a copy) then p1node is the node from the other file, and copyfrom is the filepath of the other file. .histidx The index file provides a mapping from filename to the file section in the histpack. In V1 it also contains sub-indexes for specific nodes within each file. It consists of three parts, the fanout, the file index and the node indexes. The file index is a list of index entries, sorted by filename hash (one per file section in the pack). Each entry has: - node (The 20 byte hash of the filename) - pack entry offset (The location of this file section in the histpack) - pack content size (The on-disk length of this file section's pack data) - node index offset (The location of the file's node index in the index file) [1] - node index size (the on-disk length of this file's node index) [1] The fanout is a quick lookup table to reduce the number of steps for bisecting the index. It is a series of 4 byte pointers to positions within the index. It has 2^16 entries, which corresponds to hash prefixes [00, 01, 02,..., FD, FE, FF]. Example: the pointer in slot 4F points to the index position of the first revision whose node starts with 4F. This saves log(2^16) bisect steps. dataidx = [1] [1] [,...] [1] fanouttable = [,...] (2^16 entries) fileindex = [,...] fileindexentry = [1] [1] nodeindex = [,...] [1] filename = [1] nodeindexentry = [1] [1] [1]: new in version 1. rctt| |||i|_i|_i|_t |_t|_ t|_ t|_ y)N)version) r8rr9filesentrylocations fileentriesr:r;r<r=rorn)ruirrr>s rr9zmutablehistorypack.__init__sQ  $0Xw0O  ' 1.$8!rc|xsd}tjdt|}|jj |gj ||||||fy)Nrrq)rdr#rQr setdefaultrA)rr*r"r+r,r-r.ris rr/zmutablehistorypack.addsP?skk%X7  ##Hb188 2r8[( ; rc t|jD]}|j|}|jj}|Dcic]}|d| c}fd}t t t jd|D|}|jdtjdt||tjdt|fztjt|zdz}g}|jj|i} ||z} |D].} | | | <d| z} |j!| | t| z } 0d j#|} |t| z }|j| ||f|j$|<t'j(|j+} | |j,| <ycc}w) Nrc|\}}}}}}g}|tjk7r|j||tjk7r|j||Sr)rrVrA)r"rr+r,parentsentrymaps r parentfuncz-mutablehistorypack._write..parentfuncsY%-d^"2r1a*111NN2&*111NN2&rc3&K|] }|d yw)rNr5).0rs r z,mutablehistorypack._write..s*AA1Q4ss%s%s%srqrr s %s%s%s%s%s%sr)sortedrpackfptelllistreversedr sortnodeswriterawrdr#rQr r}rrrAjoinrrrsrtr)rr*r sectionstartrr sortednodes sectionlen rawstrings locationsrYr"rawrawdatars @r_writezmutablehistorypack._writest//0H&&x0G;;++-L*11A!a1H ))*A*A:NK MMKKs8}5KKs;'78 #//#h-?!CJJ++66xDI!J.F#"( $%6!!#&#c(" $ hhz*G #g, &J MM' "%1*#=DJJx ==*113D!%DLL k1 2s G cf|jry|jtt||S)N)r)_closedrr8rclose)rrr>s rrzmutablehistorypack.closes, <<  '4F4CCrc |j}|j}|j}|j}d|jj D}t |}tjd}||zt||zz|z} g} g} d} |D] \} }}}|j|}t||z}tj|| ||| |}| jtjtjt||z| tjt|zz } t |j D]0\}}| jtj|||| dz } 2| t||zz } | j|tjd| }dj!| |zdj!| zS)Nc3vK|]1\}\}}tj|j|||f3ywr)rrsrt)rr*rYrZs rrz1mutablehistorypack.createindex..s< ,>(.64]]8 $ + + -x F,>s79s!Qrrr)r;r=rornritemsrrdcalcsizerQrr#rAr FILENAMESTRUCTr}r)r nodelocations indexoffsetfileindexformatfileindexlengthnodeindexformatnodeindexlengthr indexlensizer[fileindexentriesnodeindexentries nodecountrr*rYrZr\rr"location nodecountraws r createindexzmutablehistorypack.createindexs**//..33 ,0JJ,<,<,> u u-  5zO+ -   05 ,Hh //9M .@M{{ H  # # I44c(mDxO  y55H E EO"()<)<)>"?h ''KKx@Q #@ s=1OC CO  # #H -916<{{5)4 HH% & hh'( ) r)rr) r0r1r2__doc__r3r4rr9r/rrrrrs@rrr]s9IVKJ 9 6&pD; rr)!rdmercurial.noderr mercurialrmercurial.utilsrrr r r:rr<rrornrfrPr~r3r4rRrTrUrWrg basepackstorerrmutablebasepackrr5rrrs % #FOOL1  &v7        ( x--( VF(##FR_ 11_ r