6h:BSSKJr SSKrSSKrSSKrSSKJr SSKJrJ r J r SSK J r J rJrJrJrJrJrJr SSKJr SSKJr SS KJr SS KJr \R<"S 5r\R<"S 5r \R<"S 5r!\R<"S5r"Sr#\RHr$Sr%Sr&Sr'Sr(S=Sjr)S>Sjr*Sr+Sr,"SS5r-"SS\-5r."SS\.5r/"SS\/5r0"S S!5r1S"r2S#r3S$r4S?S%jr5S&r6S'r7S(r8S@S)jr9S*r:"S+S,5r;SAS-jr<SAS.jr=SAS/jr>SAS0jr?\<\-4\=\.4\>\/4\?\04S1.r@S2rAS3rBS4rCS5rDS6rESBS7jrFS=S8jrGS9rHSCS:jrISDS;jrJS>S<jrKg)E) annotationsN)_)hexnullrevshort)errormatchmdiffphasespycompat requirementsscmutilutil) repository)sidedata) constants) storageutils 20s20s20s20ss20s20s20s20s20ss>20s20s20s20s20sHs>B20s20s20s20s20sHslfsc[US5n[R"SU5SnUS::a*U(a"[R"[ S5U-5eg[XS- 5$)z-return the next chunk from stream as a string>lrinvalid chunk length %d) readexactlystructunpackr Abortr)streamdls 7/usr/lib/python3/dist-packages/mercurial/changegroup.pygetchunkr"/sYFAA eQ"AAv ++a :;a?@ @ v1u %%rc6[R"SUS-5$)z*return a changegroup chunk header (string)rrrpack)lengths r! chunkheaderr':s ;;ufqj ))rc0[R"SS5$)zBreturn a changegroup chunk header (string) for a zero-length chunkrrr$rr! closechunkr*?s ;;ua  rc0[[U55U-$)z3Obtain a changegroup chunk header for a named path.)r'len)paths r! _fileheaderr.Ds s4y !D ((rcDSnSnU(a(U(aURUS5nO<[USS5nO.[R"SSS9upb[R"US5nUnUHnUR U5 M SnUUbUR 5 Ub7U(aU(aURU5 $[R"U5 $$!UbUR 5 Ub7U(aU(aURU5 f[R"U5 ff=f)zWrite chunks to a file and return its filename. The stream is assumed to be a bundle file. Existing files will not be overwritten. If no filename is specified, a temporary file is created. Nswbwbis hg-bundle-s.hg)prefixsuffix)openr mkstemposfdopenwritecloseunlink)uichunksfilenamevfsfhcleanupfdcs r! writechunksrBIs BG# XXh.(D&1#++=PLB2t$BA HHQK > HHJ  C 7# '"  > HHJ  C 7# '" s A -77Jqz]JM7=)N2q-8  ,01Dqz]D 1r1c5#3^D J  !  # %A F)  ! $%%i*,-2- BNr1m,   2q# & O Buu*_r1b!B%0r1i2"> ! N  "! # saA aiL  * .$%%!F)j()00:?!OLE5 JJLU|AeH,&r1l+   2q# & 3   Buu*_r1b!B%X>r1i2HE ! E82s 3L,L1c\rSrSrSr\r\RrSr Sr SSjr Sr Sr S rS rS rS rS rSrSrSrSrSrSSjr\R4SSS4SjrSrSrg) cg1unpackeri aUnpacker for cg1 changegroup streams. A changegroup unpacker handles the framing of the revision data in the wire format. Most consumers will want to use the apply() method to add the changes from the changegroup to a repository. If you're forwarding a changegroup unmodified to another consumer, use getchunks(), which returns an iterator of changegroup chunks. This is mostly useful for cases where you need to know the data stream has ended by observing the end of the changegroup. deltachunk() is useful only if you're applying delta data. Most consumers should prefer apply() instead. A few other public methods exist. Those are used only for bundlerepo and some debug commands - their use is discouraged. 01rNcBUcSnU[RR;a"[R"[ S5U-5eUS:XaSn[RR U5nURU5UlX l U=(d 0Ul SUl g)NUNs#unknown stream compression type: %ssBZs _truncatedBZ) r compenginessupportedbundletypesr rr forbundletypedecompressorreader_stream_typeextrascallback)selfr>algr compengines r!__init__cg1unpacker.__init__"s ;C d&&;; ;++a FG#MN N %<!C%%33C8 !44R8  l  rcJURSL=(a URS:g$)Nr)rrs r! compressedcg1unpacker.compressed2szz%=$***==rc8URRU5$N)rread)rr s r!rcg1unpacker.read5s||  ##rc8URRU5$r)rseek)rposs r!rcg1unpacker.seek8s||  %%rc6URR5$r)rtellrs r!rcg1unpacker.tell;s||  ""rc6URR5$r)rr8rs r!r8cg1unpacker.close>s||!!##rc[URS5n[R"SU5SnUS::a*U(a"[R "[ S5U-5egUR(aUR5 US- $)Nrrrr)rrrrr rrr)rrr s r! _chunklengthcg1unpacker._chunklengthAsg  a ( MM% #A & 6kk!$>"?!"CDD == MMO1u rc0$)z*v10 does not have a changelog header chunkr)rs r!changelogheadercg1unpacker.changelogheaderL rc0$)z)v10 does not have a manifest header chunkr)rs r!manifestheadercg1unpacker.manifestheaderPrrchUR5nU(d0$[URU5nSU0$)zBreturn the header of the filelogs chunk, v10 only has the filenamefilename)rrr)rr fnames r! filelogheadercg1unpacker.filelogheaderTs3    IDLL!,U##rc0Uup4pVUcUnOUnSnSn X4XWXhU 4$Nrr)) r headertupleprevnodenodep1p2cs deltabaseflagsprotocol_flagss r! _deltaheadercg1unpacker._deltaheader\s5&"  I I>AArc .UR5nU(d0$[URUR5nURR U5n[URX R- 5nUR XA5nUupgppn XgXXU 0U 4 $r)rrrdeltaheadersize deltaheaderrr) rrr headerdataheaderdeltarrrrrrrs r! deltachunkcg1unpacker.deltachunkfs    I t/C/CD !!((4DLL!.B.B*BC""64=C:"N5"nLLrc#h# SnUSUR-:aSn[U5nU(dUS:aUS- nO U(aUS- nOISn[[U55v SnU[U5:aUS-nX4Uv UnU[U5:aMMt[ 5v USUR-:aMgg7f)areturns all the chunks contains in the bundle Used when you need to forward the binary stream to a file or another network API. To do so, it parse the changegroup data, otherwise it will block in case of sshrepo because it don't know the end of the stream. rrETrFiN)_grouplistcountr"r'r,r*)rparts noentrieschunkrnexts r! getchunkscg1unpacker.getchunksrs&a$....I qy " ! !#e*--CJ&;DD/)CCJ&#*, /a$....sB B2 !B20B2c URUlUR5 UR5nURR S5n U R UUUUUUS9 UR5 SUlg)Nr addrevisioncbrmdelta_base_reuse_policy) incrementrr deltaiter manifestlog getstorageaddgroupcomplete) rreporevmaptrpprogrrmrdeltasstorages r!_unpackmanifestscg1unpacker._unpackmanifestssv !""--c2   '!$;    rc ^^,^-^.^/^0^1^2^3^4^5TR5mSn TRRSS5(a/n [RTR;=(d [R TR;=(a UR S:H=(a US:Hn U (a([R"TU=(d [5SS9n OSn U-U4Sjn U-4S jn URRS U5nURRS U5 TR"S,S S0[R"UR5D6 TRm-T-R!U5 [#T-5n[$R&"U5nTRR)[+S 55 [#T-5m.TRR-[+S5[+S5US9nUR.Ul[5m0/m/U.U/4SjnU0U4SjnUR35 UR55nT-R7UU USUUU US9(dTRR9SSS9 [#T05n[#T-5nUT.- nUR;5 ASm0SUl0m50m4TRR)[+S55 TRR-[+S5[+S5US9nSnU (a[<R>U S;aU54SjnURATU UUUU US9 0nTRRSS5(aTRm-TRBn[ET.U5HtnT-RGU5RHnUURK5nURM5H/unnURU[55ROU5 M1 Mv SnU (a[<RPU S;aU44SjnTRR)[+S55 [STUU UUUUU US9 un n!U (a[<RTU S;aT-RWXT.US- 5 T5RM5Hun"un#n$U"RWXU#U$5 M T4RM5Hun%un#n$U%RWXU#U$5 M URXRS S!5 URXRS"S!5 URXRS#S!5 URXRS$S!5 TRRZ(dEURXS ==U- ss'URXS"==U - ss'URXS#==U!- ss'S!n&[#T-5n'T-R]UU'5un(m1U&[#T15[#U(5- - n&T1H"n)TU)R_5(dMU&S-n&M$ TRRZ(dURXS$==U&- ss'TRa5 US!:aS%UR;ag[cT-ReT.55URS%'[cT-ReUS- 55URS&'[gUR5m2OR[gUR5m2[cT-ReT.55T2S%'[cT-ReUS- 55T2S&'TR"S-S S0[R"T25D6 [ET.U5m,Sn*US';a:TRi5(a[jRl=nn*O[jRn=nn*T,(a[jRp"TX%T,5 U*b5T/(aT/RsT,5 OT,m/[jRt"TUU*/T/S(9 /m/US!:a%U,U-U.U1U2U4S)jm3URwS*T.-UU34S+j5 U b[yTRU 5 TRR{5 U&S!:aU&S- n+U+$U&S-n+U+$!TRR{5 f=f).aAdd the changegroup returned by source.read() to this repo. srctype is a string like 'push', 'pull', or 'unbundle'. url is the URL of the repo where this changegroup is coming from. Return an integer summarizing the change to this repo: - nothing changed or no source: 0 - more heads than before: 1+added heads (2..n) - fewer heads than before: -1-removed heads (-2..-n) - number of heads stays the same: 1 `sidedata_categories` is an optional set of the remote's sidedata wanted categories. `delta_base_reuse_policy` is an optional argument, when set to a value it will control the way the delta contained into the bundle are reused when applied in the revlog. See `DELTA_BASE_REUSE_*` entry in mercurial.revlogutils.constants. Ndebugsunbundling-stats04spullT)pullch>TRRS[U5-5 [T5$)Nsadd changeset %s )r:debugrr,)xclrs r!csmap cg1unpacker.apply..csmaps& GGMM/%(: ;r7Nrc&>TRU5$rrev)rrs r!r!cg1unpacker.apply..revmaps66!9 rssourcesurlthrowsadding changesets changesetschunksunittotalc6>UT:aTRU5 ggr)rj)rrclstartduprevss r!ondupchangelog)cg1unpacker.apply..ondupchangelogs=NN3'!rc>URU5nTceTRUR5 TRX5 gr)changelogrevisionupdatefilesregister_changeset)rrctx efilessetrs r! onchangelog&cg1unpacker.apply..onchangelogs?**3/ ,,,  +''1r) alwayscacherduplicaterevisioncbrmrs(applied empty changelog from changegroupswarn-empty-changegroup)configsadding manifests r_rcr>TRU5nU(dX4TU'gXSS-:XdeUSU4TU'gNrrget)manifestrrangetouched_manifestss r!on_manifest_rev*cg1unpacker.apply..on_manifest_revMsJ 1 5 5h ?$;>*-h7#&(Q,#66#6;@8S/-h7rrsserversvalidatecr>TRU5nU(dX4TU'gXSS-:XdeUSU4TU'gr r )filelogrrtouched_filelogss r!on_filelog_rev)cg1unpacker.apply..on_filelog_revosJ 0 4 4W =$9< ,W5#&(Q,#66#69>q3,W5rsadding file changes schangegroup-count-changesetsrschangegroup-count-revisionsschangegroup-count-filesschangegroup-count-headsnode node_last)spushsserve)revsc>T[T 5:agT R"S0[R"T5D6 THYnTR 5n[ TR U55US'US T R"S0[R"U5D6 M[ T RRSS[T5SRTVs/sHn[ USS5PM sn55 gs snf) Nrrincomings$%d incoming changes - new heads: %s s, )s changegroup)r) r,hookr strkwargscopyrrr:logjoin) unused_successrargsrAaddedrr heads_addedhookargsrs r!runhooks#cg1unpacker.apply..runhookss#d)+IIM0B0B80LM$'}}(+BGGCL(9W  . J1C1CD1IJ % GGKK#@E  #D 1C"1J #DE $EsC+schangegroup-runhooks-%020ic&>TRT5$r) _afterlock)trrr's r!#cg1unpacker.apply..stx8r)sprechangegroup)spretxnchangegroup)> unfilteredr: configboolrREVLOGV2_REQUIREMENTCHANGELOGV2_REQUIREMENTversion sidedatamodget_sidedata_helperssetr& setdefaultrr r changelog delayupdater,weakrefproxystatusr makeprogressrrrrr develwarnrrevlog_constantsKIND_MANIFESTLOGrrrrr read_delta_new_entriesrZadd KIND_FILELOG_addchangegroupfilesKIND_CHANGELOGrewrite_sidedatachangesquiet diffheads closesbranchinvalidatevolatilesetsrrdict publishingr publicdraft registernewextendadvanceboundary addpostcloserflush)6rrr+srctypeurl targetphase expectedtotalsidedata_categoriesrrmadding_sidedatasidedata_helpersrr oldrevcountrprogressrrrefilesclend changesetsr needfilesmlcsetmfnodemfestfnrnewrevsnewfilesmfstartrevendrevfl deltaheads newrevcount heads_removedhphaseallretr$rrrrr%r&r'rrs6 ` @@@@@@@@@@r!applycg1unpacker.applys<  77  h(; < <J 11T5F5FFM774;L;LL # %  # 7"  *??#,su   $   A  kk,,Y@G KK " "63 / II! )- 191C1CBKK1P  B NN2 b'K--#C GGNN134 5"gGww++- q|=,H%..DMIG ( 2  "^^%F;; )$2%(? !!?4"^FGEJ    I DM !# !  GGNN123 4ww++,a l*,H#O#448H8KKJ  ! !-%(? " Iww!!)[99^^%%!'51D11$7@@FvJ==?E % 1!,,Q6::1=!. 2"N#004DQ4GGH GGNN156 7 4,%(? ! GX #226Fq6II''w /@.E.E.G*B*6''xP/H.>.D.D.F*B*6''xP/G JJ ! !"A1 E JJ ! !"@! D JJ ! !"q.C q.C GGMMOs#T"a# H,a##a?c#\^^# Sm[UU4Sj05HnUSSv USmM g7f)zz returns an iterator of the deltas in this changegroup Useful for passing to the underlying storage system to be stored. Nc&>TRT5$r)r)chainrsr!r,'cg1unpacker.deltaiter.. sdooe&$&#$ $B M+f $FLL $EN !rrc>\rSrSrSr\r\RrSr Sr Sr g) cg2unpackerizUnpacker for cg2 streams. cg2 streams add support for generaldelta, so the delta header format is slightly different. All other features about the data remain the same. 02c"Uup4pVnSnSn X4XVXxU 4$rr) rrrrrrrrrrs r!rcg2unpacker._deltaheaders'&1#">AArr)N) r~rrrr_CHANGEGROUPV2_DELTA_HEADERrrrr2rrr)rr!rrs$.K!&&OGBrrc`^\rSrSrSr\r\RrSr Sr Sr SU4Sjjr Sr U=r$) cg3unpackeri#zUnpacker for cg3 streams. cg3 streams add support for exchanging treemanifests and revlog flags. It adds the revlog flags to the delta header and an empty chunk separating manifests and files. 03rEcUup4pVpxSn X4XVXxU 4$rr)rs r!rcg3unpacker._deltaheader0s"-8*">AArc n>[T U]UUUUUUUS9 [UR05HnUSn URR SU -5 UR 5n URRU 5RU UUUUUS9(aMj[R"[S55e g)Nrradding %s revisions s"received dir revlog group is empty) superrrzrr:rrrrrr rr) rrrrrrrmrr{rr __class__s r!rcg3unpacker._unpackmanifests5s     '!$; ! d00"5I+&A GGMM2Q6 7^^%F##..q1::+%(? ;kk!$I"JKK6rr)r})r~rrrr_CHANGEGROUPV3_DELTA_HEADERrrrr2rrrr __classcell__rs@r!rr#sA.K!&&OGOB $ L LrrcR^\rSrSrSr\r\RrSr Sr U4Sjr Sr U=r $) cg4unpackeriXzLUnpacker for cg4 streams. cg4 streams add support for exchanging sidedata. rcUup4pVpxn XEXgXU4$rr)) rrrrrrrrrrs r!rcg4unpacker._deltaheaderbs=H:biU>AArc >[T U]U5nU(dU$Uu nnnnnnn n n U (ae0n U [R-(a+[ UR 5n [ R"U 5n UUUUUUU U U 4 $r)rrrCG_FLAG_SIDEDATAr"rr3deserialize_sidedata)rrresrrrrrrrrr sidedata_rawrs r!rcg4unpacker.deltachunkfsg *J          | K88 8#DLL1L"77 EH           rr))r~rrrr_CHANGEGROUPV4_DELTA_HEADERrrrr2rrrrrs@r!rrXs/ .K!&&OGB! ! rrc \rSrSrSrSrSrg)headerlessfixupicX lXlgr)_h_fh)rr>rps r!rheaderlessfixup.__init__s rcUR(aYURSUURUSso l[U5U:a%U[URU[U5- 5- nU$[URU5$r)rr,rr)rrfrs r!rheaderlessfixup.readsf 77!dggabkJAw1vz[1s1v:66H488Q''r)rrN)r~rrrrrrr)rr!rrs (rrc#^# URbSURpCO|URUR:Xa,URn[R "[ U55nO6URn[R"UR[ U55nU"U5n[[ U5[ U5-[ U5-5v Uv U(aUv Uv UR[R-(a'URn[[ U55v Uv gg7f)z0Serialize a revisiondelta to changegroup chunks.Nr)rbasenodenullidrevisionr trivialdiffheaderr,replacediffheaderbaserevisionsizer'rrrr)rrheaderfnr1datametars r!_revisiondeltatochunksrs {{EKK 4;; &~~((T3~~(()?)?TK E?D c$i#f+-D 9 :: J  J k:::>>#h-(( ;sD+D-c&^^UU4Sjn[XS9$)z&Sort nodes for changegroup generation.c2>TRT"U55$rr)rfrlookups r!r,$_sortnodesellipsis..sBFF6!9%rrP)sorted)storenodesrrrPs `` r!_sortnodesellipsisrs$ &C % !!rc j^^^^^^^^TUn UUUUUUU4SjmU (aTRT5[[4:Xa [[pOD[U 5S:Xa[U4SjU 55un [n O[U4SjU 55upTR U 5TR U 5pXU4$)Nc>U[:Xa[$T (aU$U/nU(GaUSnUSSnUT;aTU$UT;a=URTRU5Vs/sHo3[:wdMUPM sn5 OUT ;a1URT UVs/sHo3[:wdMUPM sn5 O}[T SS5HnT R U5U:XdMUs $ [ T S5(a T R nOT RR n[R"SUT U4-5eU(aGM[$s snfs snf)aMTurn a changelog revnum into a local revnum. The ellipsis dag is stored as revnums on the changelog, but when we're producing ellipsis entries for non-changelog revlogs, we need to turn those numbers into something local. This does that for us, and during the changelog sending phase will also expand the stored mappings as needed. rrNtargets?unable to resolve parent while packing '%s' %r for changeset %r) rrP parentrevsrlinkrevhasattr display_id_revlogr r) clrevwalkpppirrclrevtolocalrev fullclnodes ischangelogprecomputedellipsisrrs r!local)_resolvenarrowrevisioninfo..localsJ G N LwQA8DO#&q))k! "--*:L*:BGmR*:LM)) "5a"8J"8B'MR"8J sAr*A}}Q'50 + 5(++"--F#]]55Fkk),2C+?@GdPEMKs E0E E'Erc34># UH nT"U5v M g7frr).0rrs r! -_resolvenarrowrevisioninfo..%s5AuQxxc34># UH nT"U5v M g7frr)rs r!rr(s6+Qa+r)rrr,rr)rrrrrlinknoderrr linkparentsrrp1nodep2noders```` ``` @r!_resolvenarrowrevisioninfors&g.KCCJ 5++C0Wg4FF'B [ Q 555 6+66ZZ^UZZ^F 8 ##rc # # U(dgURn U(aSnOU(a[XX5nSnOSnU(a/n0n0nUHznURU5nU"U5nU RU5nUUU'UU ;aUUU'O+UU ;aMF[U UUUUUUU U 5 unnnUU4UU'UUU'UR U5 M| UnSnUb-UR R U[S5[U5S9nUR RSS5nUS;a)[S 5nUR RUU-5 [RnU(a[RnO-US :Xa[RnOUS :Xa[RnUR!UUS U(+UU U S 9n[#U5HunnU(aUR%US-5 U(acWUR&nUR&W;aCUUR&unnUUlUUlU=R,[R.-slOU"UR&5nUUlUv M U(aUR35 gg7f)aCalculate deltas for a set of revisions. Is a generator of ``revisiondelta`` instances. If topic is not None, progress detail will be generated using this topic name (e.g. changesets, manifests, etc). See `revlogutil.sidedata.get_sidedata_helpers` for the doc on `sidedata_helpers`. Nsstoragesnodesrrsdevels bundle.delta)rp1rcs0config "devel.bundle.delta" as unknown value: %srrcT) nodesorder revisiondataassumehaveparentrevisions deltamoderZrmr)r7rrrrjr:r<rr,rwarnrCG_DELTAMODE_STDCG_DELTAMODE_PREVCG_DELTAMODE_P1CG_DELTAMODE_FULL emitrevisions enumeraterrrrrREVISION_FLAG_ELLIPSISrr)rrrrrforcedeltaparentprevtopicellipsesrrrrZrmrrfilteredadjustedparents linknodesrrrrrrr\ configtargetmsgr revisionsrrs r! deltagroupr/s2  B "5<   D))D/Cd|HffX&G'*OG $;&"* $ 33 ,F#' ,(*0(8%"* $ OOD !EHH 77'' ) CJ( 77>>(O into This function can be used to gather lower level information into higher level ones. )rrrrrrrrrrrrrrNr))baseotherrPs r!merge_debug_infor s  UZ !rcXSnUSSU--- nUS- nUbD[U5S-SU--[::deXR[SU-- 5- nUSU-- nOX- nUb$UceUS-U-n Ub US U UU4-- nOUS U -- nU(a US- nX- nUS - nURU5 g) z)Print one line of debug_bundle_debug_infosDEBUG-BUNDLING: rDrErFNrrGrHs (%d%% of %s %d)s (%d%%)rI)r,rJrKrN) r:rOrPrQrRrSpercentage_refextrarTrVs r! _dbg_bdl_liners DDAJ D4KC3x!|q6z*o=== /QZ899 *$$ "%%%#%8  % '+ D J+ +D    EMDLLrc UnUnUnUnSSU4SSU4SSU4/n [USSUS 5 [US SUS 5 [US S US 5 SUS-n [US SUSU S9 US(a[US SUSUS 5 U H&upn U S(dM[USXSU S 5 M( [USS5 [US SUSUSSUSS9 US(a[USSUS5 U H"upn U S(dM[USXS5 M$ US(a[USSUS5 U H"upn U S(dM[USXS5 M$ US (a[US S!US 5 US"(a[USS#US$US"S%US"S9 U H*upn U S"(dM[USU U S$U S"S%U S"S9 M, US&(a[USS'US&5 U H"upn U S&(dM[USXS&5 M$ US((a[USS)US&5 U H"upn U S((dM[USXS(5 M$ g*)+zAdisplay debug information gathered during a bundling through `ui`r^sclr_smnr`sflrrarrrsmanifestrs(for %d revlogs)rr)rrsmergerEsdeltass from-storagerrs available)rRrSrrs denied-fnrhrs denied-nbrscomputedrrcrsnativerspreviousrsparent-1N)r)r:rm cl_debug_info mn_debug_info fl_debug_inforrAmreall_infork__vs r!display_bundling_debug_infor s AAAA ua ua 5!H "aq)9':;"aq)='>?"aa(;&<= !L/ 1E"a1%5#6eDb!Xq'7;K9LMq ]   "am$4a8H6I J"a#   !+,#*+ "#b!\1-F+GHq & ' ' "a&?$@ A $%b!\1-H+IJq ( ) ) "a&A$B C b![!,<*=>    lO./$-. q    , !"2 3( !12  b![!,@*ABq ! " " "a&:$; < b![!,@*ABq  "a&8$9 :rcj\rSrSrS SjrS SjrS SjrS SjrSrS Sjr S r g)cgpackeriyNcU(deU(deX lX0lX@lXplXPlX`lXlUc [5nXlU c [5n Xl Xl Xl Xl Xl URRR(aKURRR (d&URRR"UlgSUlg)aRGiven a source repo, construct a bundler. oldmatcher is a matcher that matches on files the client already has. These will not be included in the changegroup. matcher is a matcher that matches on files to include in the changegroup. Used to facilitate sparse changegroups. forcedeltaparentprev indicates whether delta parents must be against the previous revision in a delta group. This should only be used for compatibility with changegroup version 1. builddeltaheader is a callable that constructs the header for a group delta. manifestsend is a chunk to send after manifests have been fully emitted. ellipses indicates whether ellipsis serving mode is enabled. bundlecaps is optional and can be used to specify the set of capabilities which can be used to build the bundle. While bundlecaps is unused in core Mercurial, extensions rely on this feature to communicate capabilities to customize the changegroup packer. shallow indicates whether shallow data might be sent. The packer may need to pack file contents not introduced by the changes being packed. fullnodes is the set of changelog nodes which should not be ellipsis nodes. We store this rather than the set of nodes that should be ellipsis because for very large histories we expect this to be significantly smaller. remote_sidedata is the set of sidedata categories wanted by the remote. Ncgrr))ss r!r,#cgpacker.__init__..s$r) _oldmatcher_matcherr2_forcedeltaparentprev_builddeltaheader _manifestsend _ellipsesr5 _bundlecaps_remote_sidedata _isshallow _fullclnodes_precomputedellipsis_repor:verbose debugflagnote _verbosenote)rr oldmatchermatcherr2builddeltaheader manifestsendr bundlecapsrshallow ellipsisroots fullnodesremote_sidedatas r!rcgpacker.__init__zsdzw%  %9"!1)!  J%  "!eO /!%%2! ::== )@)@ $ 2 2D  .D rc #. # SnURnURRSS5(a [5nURnUR [ S55 Sn Sn URS:Xa5URn US:Xa URn [R"UU 5n Sn Ub [5n URUUUU U S9upUH<n[URXR5HnU [U5- n Uv M M> [!5nU [U5- n [!5v Ub[#Xl5 U S US 'UR [ S 5U -5 U S nU S nU SnUb[U5US'U=(a [$R&"U5(+n0nSn SnUb [5nUR)UUUUUUU SU US9 nUHunnU(a/URS;de[+U5nU [U5- n Uv UH>n[URXR5nUHnU [U5- n Uv M M@ [!5nU [U5- n Uv M Ub[#UU5 US US'UR [ S5U -5 UR,v SnUR.(aYUR0(aH[2R4"U5VVs/sH%unnUR6UR95U4PM' nnnUR;5 UVs1sHnUR=U5iM nnSnUb [5nUR?UUUUUUUU US9 nUHun n[+U 5n![U!5n U!v UH>n[URXR5nUHnU [U5- n Uv M M@ [!5nU [U5- n Uv UR [ S5U U 4-5 M [!5v Ub[#UU5 US US'Ub[AURUU UU5 U(aURCS[EUS5US9 ggs snnfs snf7f)zqYield a sequence of changegroup byte chunks. If changelog is False, changelog data won't be added to changegroup Nrsbundling-statss%uncompressed size of bundle content: rrsstrip)generaterZrmrrs%8.i (changelog) clrevorderr_ changedfilesrclrevtomanifestrev)rZrm)rrrs%8.i (manifests) s %8.i %s rsoutgoing)rsource)#r.r:r/r r7r2rr2r*_wanted_sidedatar3r4_generatechangelogrr&r,r*r ristreemanifestgeneratemanifestsr.r'r(r+r iteritemsrrclearr generatefilesrrr)"r commonrevsclnodesfastpathlinkrevrBr7rmrrrrZr;rclstaterrrr8 clrevorder manifests changedfilesfnodesrittreer;mfdictsrflrrclrevsrr-rps" r!r>cgpacker.generates zz 77  h(9 : :(*J ^^ !EFG <<5 "33O!#'"7"7*??     !+-M11  -$ 2 E/ E#9#9E "   E l  ! Z 7/<=M/NJ+ , !12T9:]+ L) /  !'*<'8J| $(*N'2H2H2N.N  !+-M  # #       ) *-$$  LD&||~555#D)E " /JJ'='=$ECJ&DK$  LE CJ DK#$  ! Z 7.;>doo (11)<TRU5n[T5TU'T R(aUT R;dTR U5T R ;aMUR nTRX 5 TRTR U5TR U55 T R(a<TRTUR R5R55 U$TRUR5 U$TRUR U5 TRUR5 U$r) rr,r(r,rr-r r6r+rrkeysr) rrA manifestnoderPrrNclrevtomanifestrevrOmflrs r!lookupcl-cgpacker._generatechangelog..lookupcls$$Q'A OJqM~~ ***vvayD$=$==#$::L((9 '11q 377<#8 ?? ''AJJ(<(<(>(C(C(EFH!''0H $$QZZ3##AGG,HrTrrrrrrrZrm)r.rr5r(rrrr,r6r rrrr%rr,r-)rrrr>rZrmstaterrAr^genrPrNr\rOr]s`` @@@@@r!rDcgpacker._generatechangelogs(  jj$$u &#)#5  DNN5bff-E((.#&z? 4 $$QZZ6##AGG,"9  % % N JJ      & &^^M")) $ 9 9-!  zrc #^^^^^^# URn U RmST0mUUUUUU4Sjn T(Ga*TR5upURR U SS5nU (a U(dMHTR U 5nU(d/nOUR XU5nU (a U(dMU "X5n[URUUSUURUR[S5UURURUU S9 nURR URSS5(dU U4v OUHnM U (dU /4v T(aGM)gg7f)aReturns an iterator of changegroup chunks containing manifests. `source` is unused here, but is used by extensions like remotefilelog to change what is sent based in pulls vs pushes, etc. See `revlogutil.sidedata.get_sidedata_helpers` for the doc on `sidedata_helpers`. rcZ>^^T(aT(aeTR$UUUUUU4SjnU$)Nc>TUnTRTU5nURSSS9nUR5HupEnUS:Xa?TU-S-nTRU05nURXQ5n T UT U :aXU'MIMKTU-n TRU 05n U RXQ5n T UT U :dMXU'M U$)aCallback for looking up the linknode for manifests. Returns the linkrev node for the specified manifest. SIDE EFFECT: 1) fclnodes gets populated with the list of relevant file nodes if we're not using fastpathlinkrev 2) When treemanifests are in use, collects treemanifest nodes to send Note that this means manifests must be completely sent to the client before you can trust the list of files and treemanifests to send. TF)r8exactt/)r read_delta_parents iterentriesr6)rclnodemctxmdatarrfrlsubtree tmfclnodes tmfclnoderefclnodesfclnoderNrQr]rtmfnodesrSs r!lookupmflinknodeRcgpacker.generatemanifests..makelookupmflinknode..lookupmflinknodes qwwtQ'//E/J % 1 1 3HA"Tz"&(T/%-%8%8"%E $.$9$9!$D %f- 90EE,2qMF!1H#)#4#4Q#;"*"5"5a"@%f- 70CC*0QK!4 r) __getitem__) rSrrurNrLrQrOr]rts `` r!makelookupmflinknode8cgpacker.generatemanifests..makelookupmflinknodes.x!,,,  D$ #rNrFr_r`)r.rpopitemr$visitdirr_prunemanifestsrr%r(rr,r-r#rS)rrJrNrLrOrQrBrrZrmrrxrSr should_visitr prunednodeslookupfnrrr]rts ```` @@r!rFcgpacker.generatemanifestssE(zz# * $* $X"**,KD==11$s)TRU05$rr )unusedrrQs r!normallinknodes/cgpacker.generatefiles..normallinknodesszz%,,rc>^URmURnU4SjU5nUVVs0sHupEUT;dM U"U5T"U5_M snn$s snnf)Nc36># UHoT"U54v M g7frr))rrflinkrevs r!rBcgpacker.generatefiles..normallinknodes..s8%QHQK(%s)rr) rrfnoderrrUrclnrVs @r!rrsO == 8%87;LtearV|)a#b')tLLLs AAcx>T H7nURU5nURU5TUR5'M9 T "X5n[ U5[ T 5:wa@T H:upVUR US5nX4;a[ XCUTS9XC'M-U(dM6XdU'M< U$![Ra Mf=f)Nr)filenoderr ManifestLookupErrorr,r min) flogrrArlinksrirUrr commonctxsrTrs r!r)cgpacker.generatefiles..linknodess#A ! 5 13788E?0$ (4u:W-") "ud 3 >+.u|RU+KEL"U+-%L #*  !44s3B!!B98B9r`rs!empty or missing file data for %sc>TU$rr))r linkrevnodess r! lookupfilelog-cgpacker.generatefiles..lookupfilelogs #A&rr)itemF)rrrrrZrm)r$r#r.r7rr+rr:r<rr,rrfiler rrHrrrr%r(r,r-r)rrPrJrBrTrLrQrVrZrmrerArrr\rr filerevlogrrrrf filenodesrrrrrrrs ` `` @@@@@@r!rIcgpacker.generatefiless1" !}}Q (,(8(8(; !   -**&&++C M  ??2<<A**Q-rDrFr|rIrr)rr!rrysb#O/n }HF ihz#x D2prrc 0Sn [UUUSU SSUUUUUS9 $)Nc[RURURURUR 5$r)rr%rrrrrs r!r, _makecg1packer..s)!.s/!Sn [UUUSU [5UUUUUS9 $)Nc[RURURURUR UR UR5$r)rr%rrrrrrrs r!r, _makecg3packer..<s5!.builddeltaheader\sH*//   FF HH HH JJ JJ GG  rr)r5r6r7rr8r9r:r;rrs r!_makecg4packerrOs<     )\#'  r)rrrrc*[[R55nSnURR SS5(d<URR SS5(d[ R "U5(aSnU(dURS5 URR SS5=(dA [RUR;=(d [RUR;nU(dURS5 U$) NFs experimentals changegroup3s treemanifestTrs changegroup4r) r5 _packermaprZr:r/rrEdiscardrr0r1)rversionsneedv03want_v4s r!allsupportedversionsrs:??$%HG ?O<< 77  o ? ?  ! !$ ' '  ?O< E  , ,0A0A A E  / /43D3D D  Orc[U5$r)rrs r!supportedincomingversionsrs  %%rc[U5n[R"U5(a"URS5 URS5 [R UR;a"URS5 URS5 [ UR;a"URS5 URS5 U$)Nrr)rrrErrNARROW_REQUIREMENTLFS_REQUIREMENTrrs r!supportedoutgoingversionsrs#D)Hd## &&$*;*;; $+++  Orc*[[U55$r)maxrrs r! localversionrs (. //rc[U5n[RUR;aURS5 U(de[ U5$)Nr)rrGENERALDELTA_REQUIREMENTrrrs r! safeversionrsA).H,,0A0AA O8 x=rc U[U5;deUc[R"5nUc[R"5nUS:Xa+UR5(d[R "S5eU(a(US;a"[R "[S5U-5eURU5n[USn U "UUUUUUUUU S9 $)Nrs;version 01 changegroups do not support sparse file matchers)rrsSellipsis nodes require at least cg3 on client and server, but negotiated version %sr)rr8r9r:r;) rmatchmodalwaysneverr ProgrammingErrorrr narrowmatchr) r2rr7r3r4rr8r9r:r;fns r! getbundlerrs /5 55 5//#^^% % 0 0$$ J  G~-kk -     w'G G Q B  #'  rc$[US"XUS9$)Nr)r)r)r2r>rrs r! getunbundlerr s g q !"& 99rctURR(dUS:Xa0URR[S5[ U5-5 URR (aLURR S5 UH*nURR S[U5-5 M, gg)Nsbundles%d changesets found slist of changesets: s%s )r:r/r;rr,r0rr)rrrBrs r!_changegroupinfor sy ww&I- q12SZ?@ ww  ./D GGMM'CI- .rc [UUUUUUS9n[U[R"U5SS[ UR 505$)N)fastpathr7sclcount) makestreamrr chunkbufferr,missing)routgoingr2rBrr7cgstreams r!makechangegroupr sV  H  " S))*+  rcz[UUUUUS9nUR5nURn URn URn U R 5 U=(d1 UR SL=(a U [UR55:Hn URSSUS9 [X U5 URU U U U5$)N)r7r4r;s preoutgoingT)rrB) rr.commonr ancestorsofrk filternamerheadsrrr>) rrr2rBrr7r4r;bundlerrJcsetsrrLs r!rr% s ' G ?? DJ   E  E JJL 4AEVDJJL-A$A IInDI8T&)      rc Sn Sn URR[S5[S5US9n [UR05GH/n U S- n U Sn URR SU -5 U R 5 URU 5n[U5nUR5nURUUUUUUS9nU(d[R"[S55eU [U5U- - n X;dMX]n[U[U55HJnURU5nUU;aUR!U5 M-[R"[S 55e U(aGM-X] GM2 U R#5 UR%5H2un nURU 5nUHnUR'U5 M M4 X4$![Ra'n[R"[S 5U-5eSnAff=f![R(a. [R"[S 5U [+U54-5ef=f) Nrr`rrrrrs#received file revlog group is emptys#received delta base is censored: %ss#received spurious file revlog entrys+missing file data for %s:%s - run hg verify)r:r<rrzrrrrr,rrr rCensoredBaseErrorrrremoverrZr LookupErrorr)rrBrr expectedfilesr`rrmrrrr\r{rerlorr$rrneedsnewrfs r!rCrCM s1I Eww## ( !H+]$H&..3    k "  .23 YYq\ G M%%'FKK+%(?  Ekk!$J"KLL SWq[ >LEQB(GGCL:LLO++a(N&OPP ) 5L?4@ OO%5 YYq\A q &  5&& M++a FG!KL L M($$ kkDE#a&k" s&!A G9HH)"H  HAIrr})NFNNNNN)NNNNN)FFNNN)NNNFFNNN)FN)FNNN)L __future__rr5rr9i18nrrrrrr r rr r r rrr interfacesr revlogutilsrr3rr>utilsrStructrrrrrrr"r'r*r.rBrWr[rrrrrrrrrrr r rJrrrrrrrrrrrrrrrrrrrCr)rr!rsj#    #06$mmO<$mm,>?$mm,@A$mm,AB &* ! ) #N &RjFZC!C!LB+B&2L+2Lj/ +/ d ( (D",\$L  Rj0 0 &RV;rx x @ H F F %R K ( K ( K ( K ( :& 00    0f:/ : %^ =r