6h=SSKJr SSKrSSKrSSKJrJr SSKJr SSK J r SSK J r J r Jr SrS rS rS rS r"S S\ R(5r"SS\ R5r"SS\ R.5rg)) annotationsN)hexsha1nodeconstants)_)util)basepack constants shallowutils.dataidxs .datapackcT^\rSrSr\r\rU4SjrSrSrSr Sr Sr Sr S r U=r$) datapackstorec$>[TU]X5 gN)super__init__)selfuipath __class__s >/usr/lib/python3/dist-packages/hgext/remotefilelog/datapack.pyrdatapackstore.__init__"s "c[U5$r)datapack)rrs rgetpackdatapackstore.getpack%s ~rc[S5e)Ns)must use getdeltachain with datapackstore RuntimeErrorrnamenodes rgetdatapackstore.get(sGHHrcURHnURX5s $ UR5HnURX5s $ [U[ U545e![a Mef=f![a MMf=fr)packsgetmetaKeyErrorrefreshrrr%r&packs rr+datapackstore.getmeta+sJJD ||D// LLND ||D//# c$i())     "A%A6% A32A36 BBcURHnURX5s $ UR5HnURX5s $ [U[ U545e![a Mef=f![a MMf=fr)r*getdeltar,r-rr.s rr3datapackstore.getdelta:sJJD }}T00 LLND }}T00# c$i())     r1cURHnURX5s $ UR5HnURX5s $ [U[ U545e![a Mef=f![a MMf=fr)r* getdeltachainr,r-rr.s rr6datapackstore.getdeltachainIsJJD ))$55 LLND ))$55# c$i())     r1c[S5e)Nscannot add to datapackstorer"rr%r&datas radddatapackstore.addXs9::r)__name__ __module__ __qualname____firstlineno__ INDEXSUFFIX PACKSUFFIXrrr'r+r3r6r;__static_attributes__ __classcell__)rs@rrrs6KJ#I * * *;;rrc\rSrSr\r\rSrSrS/rSr Sr Sr Sr S r SS jrS rS rS rSSjrSrSrSrSrg)r\s!20siQQ(cx/nUH1up4URU5nU(aMURX445 M3 U$r)_findappend)rkeysmissingr%r&values r getmissingdatapack.getmissinggs;JDJJt$E5|, rc4[SU[U54-5e)Ns,must use getdeltachain with datapack (%s:%s))r#rr$s rr' datapack.getps  ;tSY>O O  rcURU5nUc[U[U545eUup$pVURXUU-nSnU[R "SXu5SS-- nUS- nU[R "SXu5SS-- n[R "SXu5SnUS- n[ R"XuXX-5n U $) Nr!HrIrH!Q!I)rKr,r_datastruct unpack_fromr parsepackmeta) rr%r&rOdeltabaseoffsetoffsetsizerawentrymetalenmetas rr+datapack.getmetaus 4  =D#d),- -.3+v::f}5&$$UH=a@1DD" &$$UH=a@1DD$$UH=a@! ((6;K)LM rcURU5nUc[U[U545eUup$pVURXVSS9nUuppn UR 5 XX4$)NT)r+)rKr,r _readentry freememory) rr%r&rOr^r_r`entryfilename deltabasenodedeltarcs rr3datapack.getdeltash 4  =D#d),- -.3+vd;5:2 d  33rc$URU5nUc[U[U545eURnU/nUSnURnU[ :wauU[ :wakURU-n[R"URURXU-5nUSnURU5 U[ :wa U[ :waMk/n UH.up&pURX5uppU RXXU45 M0 UR5 U $)Nr)rKr,rparamsINDEXENTRYLENGTHFULLTEXTINDEXMARKNOBASEINDEXMARK indexstartr[unpack INDEXFORMAT_indexrLrfrg)rr%r&rOrnchainr^entrylenloc deltachainr_r`rirjrks rr6datapack.getdeltachains 4  =D#d),- -((( 0 0?2##o5CMM  $++c(N"CE$AhO LL  0 0?2 38 /D637??63P 0HM   xxN O49 rc URXU-nU=R[U5- slSn[R"SUSS5SnXEXV-nXV-nU[ -n XHU n XIU [ -n U [ -n XLU S-n [R"SU 5SnXLS-U S-U-nUR U5nU(aLU S-U-n[R"SUU5SnUUS-US-U-n[R"U5nXzXU4$XzX4$)NrIrUrrWrVrXrY) rZ_pagedinlenr[rs NODELENGTH _decompressr\r r])rr_r`r+ra lengthsize filenamelenri nodestartdeltabasestartr&rj deltastart rawdeltalendeltalenrk metastartrbrawmetarcs rrfdatapack._readentrysC::f}5 X&  mmE8BQ<8; )AB, "Z/.1 .:2MN $j0 JN; == 4Q7a*q.8*CD  ' "Q1I(()DQGGy1}y1}w/FGG,,W5D== ==7 7rc.[R"U5$r)zlib decompressrr:s rrdatapack._decompressst$$rc [SX4-5e)Nscannot add to datapack (%s:%s)r"r9s rr; datapack.adds<|KLLrcURn[R"URUSUR5SnUR nXCUR -nURn[US-UR5HnXGUR -nX:wdM O UnURn XU[-n XU[-n URn X:XaXX\-n OcX:XaXX-n OWXXU - :aNXXU- S--nXUR - U -- nXU[-nX:XaXX-n OX:aUnOX:aUnXXU - :aMNg[R"URU 5$)NrrrI)rnr[rs fanoutstruct fanoutprefix _fanouttablerr _indexendrange fanoutcountrur~rort)rr&rn fanoutkeyfanoutstartindexendiendindex startnodeendnoderwrhmidmidnodes rrKdatapack._findsMM   &;(;(;!<  ""!F$5$55>>y1}f&8&89A)f///C|: C %*"45 cJ./((  %"23E _/E.(U{q00F$5$55ABcJ&67?!7E>E^C.(}}T--u55rNc>UHup4URXU5 M gr) markdataentry)rledgeroptionsrir&s r markledgerdatapack.markledger s"NH   6#rcURRU/5n[U5nUVs1sH>oDR(dUR(dM&UR UR 4iM@ nn[X5- 5S:XaZURUR;a?[R"URSS9 [R"URSS9 gggs snf)NrT) ignoremissing)sourcesr'set datarepackedgcedrir&r}rcreatedr unlinkpath indexpathpackpath)rrentriesallkeyse repackedkeyss rcleanupdatapack.cleanups..$$T2.d)*1 *1Q^^qvv QZZ '   w% &! +yy.dC TB/ ,  s %CCc#J# UR5H upp4X4v M g7fr) iterentries)rfn deltabasers r__iter__datapack.__iter__s$)-)9)9); %A)$J* > MMV/ /M  zzK}}$$s EEEr=)Fr)r>r?r@rArBrCrtroSUPPORTED_VERSIONSrPr'r+r3r6rfrr;rKrrrrrDr=rrrr\sgKJK * 4B8B%M+6Z7 C)"rrcl\rSrSrSr\r\r\Rr\Rr S/r Sr S Sjr Sr Srg) mutabledatapackiMa A class for constructing and serializing a datapack file and index. A datapack is a pair of files that contain the revision contents for various file revisions in Mercurial. It contains only revision contents (like file contents), not any history information. It consists of two files, with the following format. All bytes are in network byte order (big endian). .datapack The pack itself is a series of revision deltas with some basic header information on each. A revision delta may be a fulltext, represented by a deltabasenode equal to the nullid. datapack = [,...] revision = [1] [1] metadata-list = [, ...] metadata-item = metadata-key could be METAKEYFLAG or METAKEYSIZE or other single byte value in the future. .dataidx The index file consists of two parts, the fanout and the index. The index is a list of index entries, sorted by node (one per revision in the pack). Each entry has: - node (The 20 byte node of the entry; i.e. the commit hash, file node hash, etc) - deltabase index offset (The location in the index of the deltabase for this entry. The deltabase is the next delta in the chain, with the chain eventually terminating in a full-text, represented by a deltabase offset of -1. This lets us compute delta chains from the index, then do sequential reads from the pack if the revision are nearby on disk.) - pack entry offset (The location of this entry in the datapack) - pack content size (The on-disk length of this entry's pack data) 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 [0000, 0001,..., FFFE, FFFF]. Example: the pointer in slot 4F0A points to the index position of the first revision whose node starts with 4F0A. This saves log(2^16)=16 bisect steps. dataidx = fanouttable = [,...] (2^16 entries) index = [,...] indexentry = [1]: new in version 1. rIc.[R"U5$r)rcompressrs r _compressmutabledatapack._compresss}}T""rNc [U5S:a[[S5U-5e[U5S:wa[[S5U-5eX R;agUR U5nSR [ R"S[U55UUU[ R"S[U55U45n[R"U5nU[ R"S[U55- nXg- nURR5n[U5n X8U 4URU'URU5 g) Nisname too long %sr snode should be 20 bytes %srrUrVrX) r}r#rrrjoinr[r/r buildpackmetapackfptellwriteraw) rr%r&rjrkmetadatarawdatarr_r`s rr;mutabledatapack.adds t9u q!45<= = t9?q!>?$FG G <<  u%(( E3t9- E3u:.    ++H56;;uc'l33!!#7|+T: T grc([SURR555nSnURnUHSupgpU[R :Xa[ n OURU[5n [R"XVXU 5n XK- nMU U$)Nc36# UHunup#oAX#U4v M g7frr=).0rdboss r .mutabledatapack.createindex..s  /Cma"qM/Csr) sortedritemsrtrnullidrpr'rqr[r/) r nodelocations indexoffsetrrawindexfmtr&rr_r`deltabaselocationrhs r createindexmutabledatapack.createindexs /3||/A/A/C  -4 )DV-444$5!%2$5$5%!KK+r?r@rA__doc__rBrCrrtrorrr;rrDr=rrrrMsHDLKJ&&K00#$Lrr) __future__rr[rmercurial.noderrmercurial.i18nr mercurialrr r r r~rprqrBrC basepackstorerrmutablebasepackrr=rrrs"     ;;H**;;|n"x  n"bNh..Nr