nT(ddlZddlZddlZddlmZddlmZmZmZddl m Z ddl m Z m ZmZmZm Z mZmZmZddlmZddlmZdd lmZdd lmZej:d Zej:d Zej:d Z ej:dZ!dZ"ejFZ#dZ$dZ%dZ&dZ'd=dZ( d>dZ)dZ*dZ+GddZ,Gdde,Z-Gdde-Z.Gdde.Z/Gd d!Z0d"Z1d#Z2d$Z3 d?d%Z4d&Z5d'Z6d(Z7 d@d)Z8d*Z9Gd+d,Z: dAd-Z; dAd.Z< dAd/Z= dAd0Z>e;e,fee/fd1Z?d2Z@d3ZAd4ZBd5ZCd6ZD dBd7ZEd=d8ZFd9ZG dCd:ZH dDd;ZI d>d<ZJy)EN)_)hexnullrevshort)open)errormatchmdiffphasespycompat requirementsscmutilutil) repository)sidedata) constants) storageutils 20s20s20s20ss20s20s20s20s20ss>20s20s20s20s20sHs>B20s20s20s20s20sHslfsct|d}tjd|d}|dkr$|r!tjt d|zyt||dz S)z-return the next chunk from stream as a string>lrinvalid chunk length %d) readexactlystructunpackr Abortr)streamdls 9usr/lib/python3.12/site-packages/mercurial/changegroup.pygetchunkr"/s[FAA eQ"AAv ++a :;a?@ @ vq1u %%rc4tjd|dzS)z*return a changegroup chunk header (string)rrrpack)lengths r! chunkheaderr':s ;;ufqj ))rc.tjddS)zBreturn a changegroup chunk header (string) for a zero-length chunkrrr$rr! closechunkr*?s ;;ua  rc0tt||zS)z3Obtain a changegroup chunk header for a named path.)r'len)paths r! _fileheaderr.Ds s4y !D ((rcd}d} |r#|r|j|d}n>t|dd}n0tjdd\}}tj|d}|}|D]}|j |d}|||j |,|r|r|j|Stj|SS#||j |,|r|r|j|wtj|wwxYw)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. Nswbis hg-bundle-s.hg)prefixsuffixwb)rr mkstemposfdopenwritecloseunlink)uichunksfilenamevfsfhcleanupfdcs r! writechunksrAIs BG# XXh.(E62#++=PLB2t$BA HHQK > HHJ  C 7# '"  > HHJ  C 7# '" s A2B99AC;cxd}|dd|zzz }|dz }d}|_t|dzd|zztksJ||jtd|zz z }t|tr |d|zz }n|d |zz }d }n||z }|(||z }d}|J|d z|z}| |d ||fzz }n|d |zz }|dz }|j |y)z+Print one line of debug_unbundle_debug_infosDEBUG-UNBUNDLING:  :rNrs%14.3f seconds%10ds ds (%3d%% of %s)s (%3d%%) )r,_KEY_PART_WIDTHljust isinstancefloat write_err) r9indentkey base_valuepercentage_basepercentage_keylinepadding percentages r!_dbg_ubdl_linerVls !DDAJ D4KCG3x!|q6z*o===  /QZ899 j% ( % 2 2D Gj( (D%G  " %%%#%8  % %) D K*, ,DEMDLLrc|syt|S)Ng)sum)itemss r!_sumfrZs  u:rc g}g}g}d|fd|fd|fg}|D]9}|D],\}}|dj|s|j|3Jdd|fd|fd|fg} t|d d t|| D])\} }|s t|d | t|t|+|Dcgc]}|d  } }| j t | } t|d d | | D]B\} }|s |Dcgc]}|d  } }| j t|d | t | | Di}| D]E\} }d d d d d d d d dx|| <}|D]+}||dxxd z cc<|ds||ddzxxd z cc<-Gd}|r t|d d| D]Q\} }|r t|d | || }|D]3}||s |dz}t|d|||t|dd||||5Si}| D]\} }ggggggggdx|| <}|D]?}||dj|d |ds#||ddzj|d At |jD]#\}}|j t |||<%|r t|d d| D]S\} }|r t|d | || }| }|D]3}||s |dz}t|d||||dt|dd|||d5Uycc}wcc}w)z3display an unbundling report from debug informations CHANGELOG:s MANIFESTLOG:sFILELOG:z target-revlog unreachable changelog manifestsfilesr revisionsrdurations total-time)fulls full-cachedsnapshotssnapshot-cacheddeltas delta-cachedunknownsunknown-cachedtypezusing-cached-bases-cached)rbrcrdres type-countrDscacheds type-timestotalN) startswithappendrVr,sortrZlistrY)r9 debug_infocl_infomn_infofl_info _dispatcher0info each_inforO all_durationstotal_duration durations each_typestypesEXPECTED_TYPESttntceach_type_timet_keyvaluetds r!display_unbundle_debug_inforsGGG  '" gI %LFD!,,V4 A& (- '5  w w 7I2q,J8 T r1c3t9c*o> -77JqQz]JM7=)N2q-8 T ,01DqQz]D 1r1c5#3^D J T !  # 3%A !F)  ! $%ai*,-2- BNr1m, T  2q# & sO Bu*_r1b!B%0r1i2"> ! N T "! # saA aiL  * .$%!F)j()00:?!OLE5 JJLU|AeH,&r1l+ T  2q# & 3   Bu*_r1b!B%X>r1i2HE ! E82s $ K* K!ceZdZdZeZej ZdZdZ ddZ dZ dZ dZ d Zd Zd Zd Zd ZdZdZdZdZ ddZej2dddfdZdZy) cg1unpackeraUnpacker 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. 01rNc0|d}|tjjvr!tjt d|z|dk(rd}tjj |}|j||_||_ |xsi|_ d|_ y)NUNs#unknown stream compression type: %ssBZs _truncatedBZ) r compenginessupportedbundletypesr rr forbundletypedecompressorreader_stream_typeextrascallback)selfr=algr compengines r!__init__zcg1unpacker.__init__"s ;C d&&;; ;++a FG#MN N %<!C%%33C8 !44R8  l  rc@|jduxr|jdk7S)Nr)rrs r! compressedzcg1unpacker.compressed2szz%=$***==rc8|jj|SN)rread)rr s r!rzcg1unpacker.read5s||  ##rc8|jj|Sr)rseek)rposs r!rzcg1unpacker.seek8s||  %%rc6|jjSr)rtellrs r!rzcg1unpacker.tell;s||  ""rc6|jjSr)rr7rs r!r7zcg1unpacker.close>s||!!##rct|jd}tjd|d}|dkr$|r!t j t d|zy|jr|j|dz S)Nrrrr)rrrrr rrr)rrr s r! _chunklengthzcg1unpacker._chunklengthAsg  a ( MM% #A & 6kk!$>"?!"CDD == MMO1u rciS)z*v10 does not have a changelog header chunkr)rs r!changelogheaderzcg1unpacker.changelogheaderL rciS)z)v10 does not have a manifest header chunkr)rs r!manifestheaderzcg1unpacker.manifestheaderPrrc^|j}|siSt|j|}d|iS)zBreturn the header of the filelogs chunk, v10 only has the filenamefilename)rrr)rr fnames r! filelogheaderzcg1unpacker.filelogheaderTs3    IDLL!,U##rc8|\}}}}||}n|}d}d} ||||||| fSNrr)) r headertupleprevnodenodep1p2cs deltabaseflagsprotocol_flagss r! _deltaheaderzcg1unpacker._deltaheader\s?&b"b  I IRYE>AArc 4|j}|siSt|j|j}|jj |}t|j||jz }|j ||}|\}}}} } } } |||| | || i| f Sr)rrrdeltaheadersize deltaheaderrr) rrr headerdataheaderdeltarrrrrrrs r! deltachunkzcg1unpacker.deltachunkfs    I t/C/CD !!((4DLL!d.B.B*BC""684=C:b"iUNRRE5"nLLrc#FKd}|d|jzkrd} t|}|s|dkr|dz }n|r|dz }nFd}tt|d}|t|kr|dz}||||}|t|krft |d|jzkryyw)a"returns 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. rrDTrFiN)_grouplistcountr"r'r,r*)rparts noentrieschunkrnexts r! getchunkszcg1unpacker.getchunksrs&a$....I qy " ! !#e*--CJ&=DD/)CCJ&#*, /a$....sAj@| dvr3fd}|jC| |||| |i}jjddrj+jD}tG,|D]q}+jI|jJ}||jM}|jOD].\}}|j|tjQ|0sd}| rt>jR| dvr2fd}jj)t+dtU|| ||||| | \}} | rt>jV| dvr+jY|| ,|dz 3jOD]\}!\}"}#|!jY|| |"|#2jOD]\}$\}"}#|$jY|| |"|#|jZjd d!|jZjd"d!|jZjd#d!|jZjd$d!jj\sE|jZd xx|z cc<|jZd"xx|z cc<|jZd#xx| z cc<d!}%0rO+j#}&|%t-|&t-0z z }%|&D] }'|'0vs|'j_s|%dz}%"jj\s|jZd$xx|%z cc<ja|d!kDrd%|jvrgtc+je,|jd%<tc+je|dz |jd&<tg|j/nRtg|j/tc+je,/d%<tc+je|dz /d&<j d-d ditj/tG,|*d}(|d'vr5jirtjjlx}}(ntjjnx}}(*rtkjp||*|(2-r-js*n*-tkjt||(g-(g-|d!kDr#*+,/0fd)1|jwd*,z1fd+| tyj| jj{|%d!kr|%dz })|)S|%dz})|)S#jj{wxYw).aNAdd 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)pullchjjdt|ztS)Nsadd changeset %s )r9debugrr,)xclrs r!csmapz cg1unpacker.apply..csmaps& GGMM/%(: ;r7Nrc&j|Srrev)rrs r!rz!cg1unpacker.apply..revmaps66!9 rssourcesurlthrowsadding changesets changesetschunksunittotalc4|krj|yyr)ri)rrclstartduprevss r!ondupchangelogz)cg1unpacker.apply..ondupchangelogs=NN3'!rc|j|}Jj|jj||yr)changelogrevisionupdatefilesregister_changeset)rrctx efilessetrs r! onchangelogz&cg1unpacker.apply..onchangelogsA**3/ ,,,  +''S1r) alwayscacherduplicaterevisioncbrlrs(applied empty changelog from changegroupswarn-empty-changegroup)configsadding manifests r^rcjj|}|s||f|<y||ddzk(sJ|d|f|<yNrrget)manifestrrangetouched_manifestss r!on_manifest_revz*cg1unpacker.apply..on_manifest_revMsN 1 5 5h ?$;>*-h7#&%(Q,#66#6;@8S/-h7rrsserversvalidatecjj|}|s||f|<y||ddzk(sJ|d|f|<yrr)filelogrrtouched_filelogss r!on_filelog_revz)cg1unpacker.apply..on_filelog_revosN 0 4 4W =$9q3,W5rsadding file changes schangegroup-count-changesetsrschangegroup-count-revisionsschangegroup-count-filesschangegroup-count-headsnode node_last)spushsserve)revsct k\ry jditj D]W} j }t j ||d<|d= jditj|Y jDcgc] }| vs| }} jjddtdj|Dcgc]}t |ddc}ycc}wcc}w) Nrrincomings$%d incoming changes - new heads: %s s, )s changegroup)r) r,hookr strkwargscopyrrheadsr9logjoin) unused_successrargshnewheadsr@addedrrhookargsoldheadsrs r!runhooksz#cg1unpacker.apply..runhookss#d)+DIIM0B0B80LM$'}}(+BGGCL(9W  .! J1C1CD1IJ % ,0::<Mz#cg1unpacker.apply..stx8r)sprechangegroup)spretxnchangegroup)> unfilteredr9 configboolrREVLOGV2_REQUIREMENTCHANGELOGV2_REQUIREMENTversion sidedatamodget_sidedata_helperssetr setdefaultrr r  changelog delayupdater weakrefproxystatusrr, makeprogressrrrrr develwarnrrevlog_constantsKIND_MANIFESTLOGrrrrr readdeltarYadd KIND_FILELOG_addchangegroupfilesKIND_CHANGELOGrewrite_sidedatachangesquiet closesbranchinvalidatevolatilesetsrrdict publishingr publicdraft registernewextendadvanceboundary addpostcloserflush)4rrrsrctypeurl targetphase expectedtotalsidedata_categoriesrrladding_sidedatasidedata_helpersrrrprogressrrrefilesclend changesetsr needfilesmlcsetmfnodemfestfnrnewrevsnewfilesmfstartrevendrevfl deltaheadsr rphaseallretrrrrrrrrrrs4 ` @@@@@@@@@@r!applyzcg1unpacker.applys<  77  h(; <J 11T5F5FFM774;L;LL # %  # 7"  *??#,su   $   B  kk,,Y@G KK " "63 / DII! )- 191C1CBKK1P  B NN2 288:H--#C GGNN134 5"gGww++- q|=,H%..DMIG ( 2  "^^%F;; )$2%(? !!?4"^FGEJ    I DM !# !  GGNN123 4ww++,a l*,H#O#448H8KKJ  ! !-%(? " Iww!!)[9^^%%!'51D11$7@@FvJ002E % 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 GGMMOsS3`7` H ``!c#VKdtfdiD]}|dd|dyw)z returns an iterator of the deltas in this changegroup Useful for passing to the underlying storage system to be stored. Nc&jSr)r)chainrsr!rz'cg1unpacker.deltaiter.. sdooe&$&#$ $B M+f $FLL $FP !rrc6eZdZdZeZej ZdZdZ y) cg2unpackerzUnpacker 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,|\}}}}}d}d} ||||||| fSrr) rrrrrrrrrrs r!rzcg2unpacker._deltaheaders1&1#b"iRYE>AArN) rbrcrdre_CHANGEGROUPV2_DELTA_HEADERrrgrrrr)rr!riris$.K!&&OGBrricTeZdZdZeZej ZdZdZ dZ dfd Z xZ S) cg3unpackerzUnpacker 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. 03rDc*|\}}}}}}d} ||||||| fSrr)rls r!rzcg3unpacker._deltaheader1s.-8*b"iURYE>AArc rtt| |||||||t|jiD]}|d} |j j d| z|j} |jj| j| |||||rgtjtdy)Nrradding %s revisions s"received dir revlog group is empty)superrorr_rr9rrrrrr rr) rrrrrrrlrr`rr __class__s r!rzcg3unpacker._unpackmanifests6s k41    '!$; 2 d00"5I+&A GGMM2Q6 7^^%F##..q1::+%(? ;kk!$I"JKK6rra) rbrcrdre_CHANGEGROUPV3_DELTA_HEADERrrgrrrrr __classcell__rus@r!roro$sA.K!&&OGOB $ L LrrocHeZdZdZeZej ZdZdZ fdZ xZ S) cg4unpackerzTUnpacker for cg4 streams. cg4 streams add support for exchanging sidedata. rc(|\}}}}}}} |||||| |fSrr)) rrrrrrrrrrs r!rzcg4unpacker._deltaheadercs+=H:b"iURYE>AArc tt| |}|s|S|\ }}}}}}} } } | rJi} | tjzr*t |j } tj| } ||||||| | | f Sr) rtrzrrCG_FLAG_SIDEDATAr"rrdeserialize_sidedata)rrresrrrrrrrrr sidedata_rawrus r!rzcg4unpacker.deltachunkgsK1(;J          | K88 8#DLL1L"77 EH           r) rbrcrdre_CHANGEGROUPV4_DELTA_HEADERrrgrrrrrwrxs@r!rzrzYs/ .K!&&OGB! ! rrzceZdZdZdZy)headerlessfixupc ||_||_yr)_h_fh)rr=rs r!rzheaderlessfixup.__init__src|jrY|jd||j|dc}|_t||kr%|t|j|t|z z }|St|j|Sr)rr,rr)rrPrs r!rzheaderlessfixup.readsh 77!dggabkJAtw1vz[1s1v:66H488Q''rN)rbrcrdrrr)rr!rrs (rrc#DK|jd|j}}ny|j|jk(r+|j}t j t |}n5|j}t j|jt |}||}tt |t |zt |z||r|||jtjzr'|j}tt ||yyw)z0Serialize a revisiondelta to changegroup chunks.Nr)rbasenodenullidrevisionr trivialdiffheaderr,replacediffheaderbaserevisionsizer'rrr}r)rrheaderfnr0datametars r!_revisiondeltatochunksrs {{EKK 4;; &~~((T3~~(()?)?TK E?D c$i#f+-D 9 :: J  J k:::>>#h-(( ;sDD c,fd}t||S)z&Sort nodes for changegroup generation.c2j|Srr)rPrlookups r!rz$_sortnodesellipsis..sBFF6!9%rrO)sorted)storenodesrrrOs `` r!_sortnodesellipsisrs$ &C %S !!rc ^|} fd| rjttfk(r tt} } nBt| dk(rtfd| D\} t} ntfd| D\} } j | j | } } | | |fS)Nc\|tk(rtS r|S|g}|r|d}|dd}|vr|S|vr9|jj|Dcgc]}|tk7s |c}n| vr-|j |Dcgc]}|tk7s |c}n~t ddD]} j ||k(s|cSt j dr j}n jj}tjd| |fz|rtScc}wcc}w)aTurn 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) rr; parentrevsrlinkrevr safehasattr display_id_revlogr r) clrevwalkpppirrclrevtolocalrev fullclnodes ischangelogprecomputedellipsisrrs r!localz)_resolvenarrowrevisioninfo..localsO G N LwQA8DO#&q))k! "--*:L*:BbGmR*:LM)) "5a"8J"8BB'MR"8J sAr*A}}Q'50 + ##E84"--F#]]55Fkk),2C+?@GPEMKsD$D$D)D)rc3.K|] }|ywrr).0rrs r! z-_resolvenarrowrevisioninfo..&s5AuQxc3.K|] }|ywrr)rs r!rz-_resolvenarrowrevisioninfo..)s6+Qa+r)rrr,rr)rrrrrlinknoderrr linkparentsrrp1nodep2noders```` ``` @r!_resolvenarrowrevisioninfors&g.KCCJ 5++C0Wg4FF'B [ Q 555 6+66BZZ^UZZ^FF 68 ##rc #K|sy|j} |rd}n|rt||| |}d}nd}|rg}i}i}|D]t}|j|}||}| j|}|||<|| vr|||<n(|| vrAt| ||||||| | \}}}||f||<|||<|j |v|}d}|0|j j |tdt|}|j jdd}|dvr)td }|j j||ztj}|rtj}n+|d k(rtj}n|d k(rtj}|j!||d | || | }t#|D]\}}|r|j%|dz|ra|j&}|j&vrV||j&\}}||_||_|xj,tj.zc_n||j&}||_||r|j3yyw)a6Calculate 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)rp1rbs0config "devel.bundle.delta" as unknown value: %srrbT) nodesorder revisiondataassumehaveparentrevisions deltamoderErlr)r#rrrrir9r(rr,rwarnrCG_DELTAMODE_STDCG_DELTAMODE_PREVCG_DELTAMODE_P1CG_DELTAMODE_FULL emitrevisions enumeraterrrrrREVISION_FLAG_ELLIPSISrr)rrrrrforcedeltaparentprevtopicellipsesrrrrErlrrfilteredadjustedparents linknodesrrrrrrrF configtargetmsgr revisionsrrs r! deltagroupr0s2  B "5%V<   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))baseotherrOs r!merge_debug_infors"  S U3Z !rcJd}|dd|zzz }|dz }|Dt|dzd|zztksJ||jtd|zz z }|d|zz }n||z }|"|J|dz|z} | |d | ||fzz }n|d | zz }|r |dz }||z }|d z }|j|y) z)Print one line of debug_bundle_debug_infosDEBUG-BUNDLING: rCrDrENrrFrGs (%d%% of %s %d)s (%d%%)rH)r,rIrJrM) r9rNrOrPrQrRpercentage_refextrarSrUs r! _dbg_bdl_liners DDAJ D4KC3x!|q6z*o===  /QZ899 *$$  "%%%#%8  % '+ D J+ +D     EMDLLrc  |}|}|}|}dd|fdd|fdd|fg} t|dd|d t|d d|d t|d d |d d|dz} t|d d|d| |drt|d d|d|d | D]!\} } } | ds t|d| | d| d #t|ddt|d d|d|dd|d|drt|dd|d| D]\} } } | ds t|d| | d|drt|dd|d| D]\} } } | ds t|d| | d|d rt|d d!|d |d"rt|dd#|d$|d"d%|d"| D]'\} } } | d"s t|d| | d$| d"d%| d")|d&rt|dd'|d&| D]\} } } | d&s t|d| | d&|d(rt|dd)|d&| D]\} } } | d(s t|d| | d(y*)+zAdisplay debug information gathered during a bundling through `ui`r]sclr^smnr_sflrr`rrrsmanifestrs(for %d revlogs)rr)rrsmergerDsdeltass from-storagerrs available)rQrRrrs denied-fnrgrs denied-nbrscomputedrrbrsnativerspreviousrsparent-1N)r)r9rl cl_debug_info mn_debug_info fl_debug_inforr@mrOall_infork__vs r!display_bundling_debug_infor!s AAAA ua ua 5!H "aq)9':;"aq)='>?"aa(;&<= !L/ 1E"a1%5#6eDb!Xq'7;K9LM2q ]  "aAm$4a8H6I J"a#   !+,#*+ "#b!\1-F+GHAq & ' "aA&?$@ A $%b!\1-H+IJ2q ( ) "aA&A$B C b![!,<*=>    lO./$-. 2q   , !"2 3( !12  b![!,@*AB2q ! " "aA&:$; < b![!,@*AB2q  "aA&8$9 :rcXeZdZ ddZ d dZ d dZ d dZdZ d dZy) cgpackerNc|sJ|sJ||_||_||_||_||_||_| |_| t}||_| t} | |_ | |_ | |_ | |_ ||_ |jjjrF|jjj s&|jjj"|_yd|_y)a Given 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. Ncyrr))ss r!rz#cgpacker.__init__..s$r) _oldmatcher_matcherr_forcedeltaparentprev_builddeltaheader _manifestsend _ellipsesr! _bundlecaps_remote_sidedata _isshallow _fullclnodes_precomputedellipsis_repor9verbose debugflagnote _verbosenote)rr oldmatchermatcherrbuilddeltaheader manifestsendr bundlecapsrshallow ellipsisroots fullnodesremote_sidedatas r!rzcgpacker.__init__{sdzw%  %9"!1)!  J%  "!eO /!%%2! ::== )@)@ $ 2 2D  .D rc #Kd}|j}|jjddr t}|j}|j t dd} d} |jdk(r3|j} |dk(r |j} tj|| } d} | t} |j|||| | \} }|D]:}t|j||jD]}| t|z } |<t!}| t|z } t!|t#|| | d |d <|j t d | z| d }| d }| d}|t||d<|xrt%j&| }i}d} d}| t}|j)||||||| d| | }|D]\}}|r-|jdvsJt+|}| t|z } ||D]<}t|j||j}|D]}| t|z } |>t!}| t|z } ||t#|||d |d<|j t d| z|j,d}|j.rP|j0rDt3j4|Dcgc]$\}}|j6|j9|f&}}}|j;|Dchc]}|j=|}}d}| t}|j?|||||||| | }|D]\} }t+| }!t|!} |!|D]<}t|j||j}|D]}| t|z } |>t!}| t|z } ||j t d| | fzt!|t#|||d |d<|tA|j|| |||r!|jCdtE|d|yycc}}wcc}ww)zYield 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)generaterErlrrs%8.i (changelog) clrevorderr^ changedfilesrclrevtomanifestrev)rErl)rprrs%8.i (manifests) s %8.i %s rsoutgoing)rsource)#rr9rrr#r rrr_wanted_sidedatarr _generatechangelogrrr,r*rristreemanifestgeneratemanifestsr.rrrr iteritemsrrclearr generatefilesrrr)"r commonrevsclnodesfastpathlinkrevrr#rlrrrgrErrclstaterrrr7 clrevorder manifests changedfilesfnodesrittreer:mfdictsrPlrrclrevsrr-rs" r!rzcgpacker.generates zz 77  h(9 :(*J ^^ !EFG <<5 "33O!#'"7"7*??     !+-M11  -$ 2 E/ E4#9#9E "   E l  ! Z 7/<=M/NJ+ , !12T9:]+ L) /  !'*<'8J| $(*N'2H2H2N.N  !+-M  # #       ) *-$$  LD&||~555#D)E " /JJt'='=$ECJ&DK$  LE CJ DK#$  ! Z 7.;>doo (11)<.lookupcls$$Q'A OJqM~~ ***vvayD$=$==$%::L((q9 '11q 377<#8 ?? ''AJJ(<(<(>(C(C(EFH!''0H $$QZZ3##AGG,HrTrrrrrrrErl)rrr!rrrrr,r"rrrrrrrr)rrrrrErlstaterr@r3genr&r$r1r%r2s`` @@@@@r!rzcgpacker._generatechangelogs (  jj$$u &#)#5  DNN5bff-E((.#&z? 4 $$QZZ6##AGG,"9  & & P JJ      & &^^M")) $ 9 9-!  czrc #pK|j} | jdifd} rj\} } |jj | dd}| r|s9j | }|sg}n|j || |}| r|sg| | | }t|j||d||j|jtd||j|j||  }|jj |jdds| |fn|D]}| s| gfryyw)a8Returns 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`. rcDrrJjSfd}|S)Nc|}j|jd}|jD]\}}}|dk(r>|zdz}j|i}|j||} | |ksD|||<J|z} j| i} | j||} | | ks|| |<|S)aPCallback 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. T)rt/)rreadfast iterentriesr")rclnodemdatarrPrVsubtree tmfclnodes tmfclnoderOfclnodesfclnoder$r'r2rtmfnodesr)s r!lookupmflinknodezRcgpacker.generatemanifests..makelookupmflinknode..lookupmflinknodes qa(11$1? % 1 1 3HAq"Tz"&(T/%-%8%8"%E $.$9$9!V$D %f- 90EE,2JqM 1H#)#4#4Q#;"*"5"5a"@%f- 70CC*0HQK!4 r) __getitem__) r)rrFr$r"r'r%r2rEs `` r!makelookupmflinknodez8cgpacker.generatemanifests..makelookupmflinknodes.x!,,,  B$ #rNrFr^r4)rrpopitemrvisitdirr_prunemanifestsrrrrrrrr))rr r$r"r%r'rrrErlrrHr)r should_visitr prunednodeslookupfnrrr2rEs ```` @@r!rzcgpacker.generatemanifestssG(zz# ) $) $V"**,KD%==11$s).normallinknodesszz%,,rc|j|j}fd|D}|Dcic]\}}|vs |||c}}Scc}}w)Nc32K|]}||fywrr))rrflinkrevs r!rzBcgpacker.generatefiles..normallinknodes..s8%QHQK(%s)rr) rrfnoderrXr+rYclnr,s @r!rUz/cgpacker.generatefiles..normallinknodessN == 8%87;LtearV|a#b')tLLLs A A cj D]6} |j|}|j||j<8 ||}t |t k7r= D]8\}}|j |d}||vrt |||||<1|s4|||<:|S#tj$rYwxYw)Nr)filenoderr ManifestLookupErrorr,rmin) flogrr@rZlinksrSr+rr commonctxsr*rUs r!rz)cgpacker.generatefiles..linknodess#A ! 5 13788E?0$ (e4u:W-")B "ud 3 E>+.uU|RU+KE%L"+-E%L #*  !44s3BB21B2r_rs!empty or missing file data for %sc|Srr))r linkrevnodess r! lookupfilelogz-cgpacker.generatefiles..lookupfilelogs #A&rr)itemF)rrrrrErl)rrrr#rrrr9r(rr,rrfiler rrrrrrrrrr)rr&r rr*r"r'r,rErlrOr@rrrFrr filerevlogrerPrQrP filenodesrr[rrrbrdrUs ` `` @@@@@@r!rzcgpacker.generatefiless." !}}Q(8(8(; !   -**&&++C M  ??2<<A$**Q-.s)!.s/!.<s5!.builddeltaheader\sH*//   FF HH HH JJ JJ GG  rr)r r rrrrrrrvrns r!_makecg4packerrzOs<     )\#'  r)rrjrprcttj}d}|jj dds1|jj ddst j |rd}|s|jd|jj ddxs:tj|jvxstj|jv}|s|jd|S) NFs experimentals changegroup3s treemanifestTrps changegroup4r) r! _packermapr/r9rrrdiscardrrr)rversionsneedv03want_v4s r!allsupportedversionsrs:??$%HG ?O< 77  o ?  ! !$ '  ?O< E  , ,0A0A A E  / /43D3D D  Orct|Sr)rrs r!supportedincomingversionsrs  %%rcnt|}tj|r"|jd|jdtj |jvr"|jd|jdt |jvr"|jd|jd|S)Nrrj)rrrr}rNARROW_REQUIREMENTLFS_REQUIREMENTrr~s r!supportedoutgoingversionsrs#D)Hd# &&$*;*;; $+++  Orc*tt|Sr)maxrrs r! localversionrs (. //rct|}tj|jvr|jd|sJt |S)Nr)rrGENERALDELTA_REQUIREMENTr}r_rs r! safeversionrsA).H,,0A0AA O8 x=rc v|t|vsJ|tj}|tj}|dk(r%|jst j d|r%|dvr!t j td|z|j|}t|d} | |||||||||  S)Nrs;version 01 changegroups do not support sparse file matchers)rrjsSellipsis nodes require at least cg3 on client and server, but negotiated version %sr)rrrrr) rmatchmodalwaysneverr ProgrammingErrorrr narrowmatchr|) rrrr r rrrrrfns r! getbundlerrs /5 55 5//#^^% % 0$$ J  G~-kk -     w'G G Q B  #'  rc*t|d|||S)Nr)r)r|)rr=rrs r! getunbundlerr s g q !"c& 99rcZ|jjs|dk(r0|jjtdt |z|jj rJ|jj d|D])}|jj dt|z+yy)Nsbundles%d changesets found slist of changesets: s%s )r9rr'rr,rrr)rrrrs r!_changegroupinfor sy ww&I- q12SZ?@ ww  ./D GGMM'CI- .rc t||||||}t|tj|ddt |j iS)N)fastpathrsclcount) makestreamrr chunkbufferr,missing)routgoingrrrrcgstreams r!makechangegroupr sV  H  " S))*+  rctt|||||}|j}|j} |j} |j} | j |xs,|j duxr| t|jk(} |jdd|t|| ||j| | | |S)N)rr rs preoutgoingT)rr) rrcommonr ancestorsofrj filternamerr rrr) rrrrrrr rbundlerr csetsr r"s r!rr% s ' G ?? DJ   E  E JJL 4AEVDJJL-A$A IInDI8T5&)      rc d} d} |jjtdtd|} t|jiD] } | dz } | d} |jj d| z| j |j| }t|} |j}|j||||||}|stjtd | t||z z } | |vs|| }t|t|D]F}|j|}||vr|j!|*tjtd |r|| =#| j#|j%D]/\} }|j| }|D]} |j'|1| | fS#tj$r&}tjtd |zd}~wwxYw#tj($r-tjtd | t+|fzwxYw) Nrr_rrrrsrs#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)r9r(rr_rrrrgr,rrr rCensoredBaseErrorrrremoverrYr LookupErrorr)rrrr expectedfilesrJrrlrrrrFr`rOrVorrrqneedsnewrPs r!r/r/M s7I Eww## ( !H+]$H&..3    k "  .23 YYq\ G M%%'FKK+%(?  Ekk!$J"KLL SWq[ >aLEQB(GGCL:LLO++a(N&OPP ) aL?4@ OO%5 YYq\A q & e 5&& M++a FG!KL L M($$ kkDE#a&k" s&$AG,HG>!G99G>AIrra)NFNNNNN)NNNNN)FFNNN)NNNFFNNN)FN)FNNN)Kr4rr%i18nrrrrrr rr r rr r rrr interfacesr revlogutilsrrrr*utilsrStructrfrmrvrrrr"r'r*r.rArVrZrrrirorzrrrrrrrrIrrrrorsrwrzr|rrrrrrrrrrr/r)rr!rst     #06+fmmO<+fmm,>?+fmm,@A+fmm,AB &* ! ) #N &RjFZD!D!NB+B&2L+2Lj/ +/ d ( (D",\$L  Rj0 0 &RV;rw w ~ H F F %R K ( K ( K ( K ( :& 00    0f:/ : %^ =r