6hkxSSKJr SSKrSSKrSSKJr SSKJr SSKJ r J r J r J r JrJrJrJr SSKJr SSKJrJrJrJrJrJr \R6"S 5r"S S \ R:5rS S jrS!S jr S!Sjr!Sr"Sr#Sr$S"Sjr%Sr&Sr'Sr(Sr)S#Sjr*S!Sjr+"SS5r,"SS5r-"SS5r.Sr/g)$) annotationsN)_)short)encodingerrorlockmdiffpolicyscmutilutilvfs)procutil) constants contentstoredatapack historypack metadatastore shallowutilosutilc\rSrSrSrg)RepackAlreadyRunningN)__name__ __module__ __qualname____firstlineno____static_attributes__r"GGLL F ww($<== $} #x//MUMfMr c [US5(a~[R"UR6n[R "UR SS06n[R"U[R5n[UUUU[RUS9 [URS5(a[U5upVUupxn Uupn [R"U 6n[R "U SS06n[UUUU [RUS9 [R"USS06n[R "U SS06n[UUUU[RUS9 gg)zIIf ``packsonly`` is True, stores creating only loose objects are skipped.shareddatastoresallowincompleteToptions datastoreN)hasattrrunioncontentstorer7runionmetadatastoresharedhistorystoresrgetcachepackpathrFILEPACK_CATEGORY _runrepack manifestlog_getmanifeststoresTREEPACK_CATEGORY) r/r: datasource historysourcepackpath localdata shareddata lpackpathldstoreslhstores spackpathsdstoresshstoress r! fullrepackrQ4slt'((!33T5J5JK %88  % % 7; // )--        ' '  t-- 24 8 (1% X(2% X"33X> %88  '+        ' '  "33  '+ &88  '+        ' '  5.r c [US5(aU[R"U[R5n[ UUR URU[RUS9 [URS5(aQ[U5up4UupVnUupn [ UU U U[RUS9 [ UUUU[RSUS9 gg)zThis repacks the repo by looking at the distribution of pack files in the repo and performing the most minimal repack to keep the repo in good shape. r7r9r;T)allowincompletedatar:N) r<rr@rrA_incrementalrepackr7r?rCrDrE) r/r:rHrIrJrKrLrMrNrOrPs r!incrementalrepackrUlst'((// )--     ! !  $ $   ' '  t-- 24 8 (1% X(2% X       ' '         ' ' $ !.r cURRnURRnURRnURRn[ R "U[R5n[ R"URRR[R5nXbU4XQU44$N) rCr7localdatastoresr?localhistorystoresrr@rrEgetlocalpackpathsvfsr base)r/r7rXr?rYsharedpackpath localpackpaths r!rDrDs''88&&66O**>>))<< 11 i))N 00 I77M );< +>? r c^^^[U4SjU55n[U4SjU55nU$)Nc3d># UH%n[RRTU5v M' g7frW)ospathjoin).0prHs r! _topacks..s#:Eqh**Es-0c34># UH nT"U5v M g7frWr)rdre constructors r!rfrgs/AQs)list)rHfilesripathspackss` ` r!_topacksrns( :E: :E // /E Lr c URRSS5nUS::aU$SS/nUVVVs1sHbupVnURU:dM[RR U5SU;dM@[RR U5SiMd nnnnUHn [RR X5n UHon X-nURRSU[R"[R"U5R54-5 [R"U5 Mq M UV s/sH-n [RRU S5U;dM+U PM/ sn $s snnnfs sn f)zoDeletes packfiles that are bigger than ``packs.maxpacksize``. Returns ``files` with the removed files omitted.packss maxpacksizers .datapacks.dataidxrs#removing oversize packfile %s (%s) ) r) configbytesst_sizerarbsplitextrcdebugr bytecountstatunlinkbasename) r/folderrkmaxsize VALIDEXTSrbftyperv oversized rootfnamerootpathextrows r!_deletebigpacksrsLgg!!(N;G!| {+I "'!& D LL7 " "(*(8(8(>q(AY(N "q!!&  77<<2C>D GGMM7 (=(=>?@  IIdO ! N5CBGG$4$4SV$.s$aJq(2H2H$I9#2 2c3h# UH(n[U[R5(aM$Uv M* g7frWrrhistorypackstorers r!rfrs)A![99: rc3*# UH upo1v M g7frWr)rdfmodervs r!rfrs0}qsc3h# UH(n[U[R5(aM$Uv M* g7frWrrs r!rfrs)A![99: rr8) fullhistoryr:)rmkstickygroupdirr)rlistdirrrn_computeincrementaldatapackrextend_computeincrementalhistorypackr_allpackfileswithsuffix PACKSUFFIX INDEXSUFFIXrBrr=rr>) r/r; historystorerHcategoryrSr:rk datapacks historypacksallhistoryfilesallhistorypackss r!rTrTst  (3 NN8$N /E DE 2E-dggu=x?P?PI&tww6L . {%%{'>'>O00O   &&  (;  ((,MM!44  .2  r cURSS5URSS5URSS5URSS5URSS5S.n[U[R [R 5n[X25$)N remotefilelogsdata.gencountlimitsdata.generationssdata.maxrepackpackssdata.repackmaxpacksizesdata.repacksizelimit gencountlimit generationsmaxrepackpacksrepackmaxpacksizerepacksizelimit) configint configlistrqrrrr_computeincrementalpackr)rkopts packfiless r!rrs,,'79NO &68KL<< 4 !nn 7 NN 5  D( x""H$8$8I #9 33r c URSS5URSSS/5URSS5URSSS5URSS5S .n[U[R [R 5n[X25$) Nrshistory.gencountlimitshistory.generationss100MBshistory.maxrepackpacksshistory.repackmaxpacksizes400MBshistory.repacksizelimitr)rrrqrrrrrrs r!rr$s,, 6  4xj << 7 !nn :H NN 8  D$( {%%{'>'>I #9 33r c/nUVVVs1sHupEodiM nnnnUHJupnURU5(dMUS[U5*n X-U;aM7URXU45 ML U$s snnnfrW)endswithlenr() rk packsuffix indexsuffixresultfnrrvfilesetfilenameprefixs r!rr=s F(-.nbrG. %  ,, ,S_,-   0  vT*+!& M/sA-c "^ [[SUS5SS95nURS5 /n[[ U55HnUR/5 M 0m UHPupVnUR nXS:aMUT U'[ U5H upIX:dM X4RU5 MN MR /n [ U5H;upI[ X45US:dMU R[X4SU 4SjS 95 O U S S n U S S n [U 4S jU 55n XS :afU (a_[ U 5US:aMU RU R55 U T U S- n XS :aU (a[ U 5US:aMMU $)aHGiven a set of pack files along with the configuration options, this function computes the list of files that should be packed as part of an incremental repack. It tries to strike a balance between keeping incremental repacks cheap (i.e. packing small things when possible, and rolling the packs up to the big ones over time). c3N# UHn[R"U5v M g7frW)r sizetointrs r!rf*_computeincrementalpack..Ys@+?aq!!+?s#%rT)reverserrrc>TU$rWr)xsizess r!)_computeincrementalpack..ys 58r )rkeyNc3.># UH nTUv M g7frWr)rdnrs r!rfrs3{!U1X{srr) rjsortedr(rangerrr enumeratersumpop)rkrlimits generationsirrrvsizelimitgenpacks chosenpacks repacksizers @r!rrNs@4+?@$OF MM!K 3v; 2  E#d|| +, , f !&)HA|%%f-* $"Hf% {~ &6!7 7 OO{~t9KL   &23-K}H3{33J,--   t$56 68<<>*eKO,, ,--   t$56 6 r c  [R"URU5 SnURRSS5nU(dUn[ UUUUUUUUS9n [ R "URU5n [R"URU5n U RX5 SSS5 SSS5 g![Ra [[S55ef=f!,(df  NC=f!,(df  g=f)NcURXS9nXR5R5nURR SS5n[ R "5U- nUSU:$)ztCheck if the file node is older than a limit. Unless a limit is specified in the config the default limit is taken. )fileidrsnodettlr)filectxlinkrevdater)rtime)r/rnoderfiletimettlrs r!isold_runrepack..isoldsb,,x,5)*//1gg 0*= c!{U""r rsgcrepack)gcrr:s3skipping repack - another repack is already running)rrr)r+repackerrmutabledatapackrmutablehistorypackrunrLockHeldrr) r/datahistoryrHrrr:rgarbagecollectpackerdpackhpacks r!rBrBs  (3 #WW''(8+FN      F  ! !$''8 4  + +DGGX >%  5(? 5 4>> *. ? > 5 4s6;"C?C.C1C?)C++C.. C< 8C?? D c vU(d [5nOUn/SQnURRSSS5nU(aURSU-5 URRSSS5nU(aURSU-5 SR U5nSU-/n[ R "X5n[5nSn[UR5Hn X R5RU5upU cUbU n U(aU RU5n U nURU 5 [U 5[LaCU R5H-upUS S cMURU"XS S 55 M/ MU R5HupURU"X55 M M U$) zComputes a keepset which is not garbage collected. 'keyfn' is a function that maps filename, node to a unique key. 'lastkeepkeys' is an optional argument and if provided the keepset function updates lastkeepkeys with more keys and returns the result. ).sdraft()sparents(draft())rs pullprefetchNs(%s)sbgprefetchrevs+ssort((%s), "topo")r)setr)configr(rcr revrangereversed_list manifestctxread_any_fast_deltadiffaddtypedictitems)r/keyfn lastkeepkeyskeepkeysrevs prefetchrevskeep processed lastmanifestr delta_frommfullrrfilenodes r!keepsetr s 5 3D77>>"2OTJL Gl*+77>>"24EtLL Gl*+ 99T?D !D ( )D   D 'DILdjj !++-AA)L  ,":DFF<(L a 7d?#$'')71:)LLxa!<=#, '(ggi" U867'0)". Or cF\rSrSrSrS SjrSrSrSrSr S r S r g) rizVClass for orchestrating the repack of data and history information into a new format. Nc XlX lX0lX@l[R "U5UlX`lXlUR(a+U(d [S5e[US5Ul Xpl gg)Ns*Function 'isold' is not properly specifiedcX4$rWr)rrs r!r#repacker.__init__.. svr ) r/rrrrgetunitsunitrr: ValueErrorr rr) selfr/rrrrrrr:s r!__init__repacker.__init__sg   &&&x0      !NOO#D*=>DMJ r c[5n[R"[UR5SSSS9 URR S5 UR RX0RS9 URRX0RS9 URX15 URX25 URHnURU5 M SSS5 g!,(df  g=f)Ns repacklockr)desctimeouts prerepackr9) repackledgerlockmodr repacklockvfsr/hookr markledgerr:r repackdata repackhistorysourcescleanup)r targetdata targethistoryledgersources r!r repacker.runs \\ $)) $m$  IINN< ( II  > LL # #FLL # A OOF /   v 5!..v&)   s B(C&& C4c ^^U(dU$SUU4Sjjn[U5n[[XFSS95nUR(a?URSTSR UVs/sHn[ U5PM sn54-5 [ U5H<upUS:XaTRRS4XY'M'XHS- n XU SS-4XY'M> UV s/sH oU;dM U PM nn X4- nU$s snfs sn f) aAReorderes ``orphans`` into a single chain inside ``nodes`` and ``deltabases``. We often have orphan entries (nodes without a base that aren't referenced by other nodes -- i.e., part of a chain) due to gaps in history. Rather than store them as individual fulltexts, we prefer to insert them as one chain sorted by size. rc>TRRTU5n[RU;aU[R$U$rW)rgetmetar METAKEYSIZE)rdefaultmetarrs r!getsize'repacker._chainorphans..getsize0s=99$$Xt4D$$,I1122r T)rrs%s: orphan chain: %s s, r)r) rrj debugflagrtrcrrr/nullid) rr)rnodesorphans deltabasesr,rrrparentrs ` ` r! _chainorphansrepacker._chainorphans$sL  /vgDAB << HH)UZZ7(C7aq7(CDEF  !)GAAv$(II$4$4a#8   Q$*v,>q,AA,E#F  * "6Eqg%5E6  )D7s C- C2C2c  ^'URRnURSSS5n0nURR 5H>nUR (dMXeR UR05UR'M@ SnUR[S5UR[U5S9n[UR55GHupURU5 0n [!SU 55m'/n UR[S5S [T'5S9n [#T'5HGupX;aM U RU5 U RUR$R'XU S 95 MI U R-5 [![/UR1U 555n[U 5S:aUR3S [U 5-5 UR5[U 55 [![7U'4S jU55nUR8(a[/nUHQnX4UR:;a,UR=URX5(a S XlM@UR+U5 MS Un0n[A5n[A5n[AT'5m'UR[S5S [U5S9n[#U5GHupURU5 URCUS5nUcEURRDSnnURRDS4UU'URGU5 OUunnURGU5 U RCU5nU(dMUunnnnU(aURRDnUU:dMUURRD:wa UUS-4UU'UURRD:wdGMUUS-4UU'GM URISS5(aUU- nURKX9UUU5n[#U5GHWupUUunnUURRD:waURLROX5nUun n!n"n#U#RC[PRR5n$U!U :wd U"U:wdU$cYURLRCU U5n%URLRCX5n&[U&5n$[TRV"U%U&5n OAURLRCX5n [U 5n$URLRYX5n#[PRRU#;aU$U#[PRR'URGXUU U#5 S Xl-GMZ UR-5 US- nGM UR-5 UR]US9 g![(a U R+U5 GMf=f)Nrps maxchainlenirsrepacking datartotalc3$# UHov M g7frWrrdrs r!rf&repacker.repackdata..^2'$'sbuilding historysnodesknowns%repackdata: %d nodes without history c>UT;$rWr)rr0s r!r%repacker.repackdata..s DEMr Tsprocessing nodesrr#schainorphansbysizer#)/r/r)rentriesvaluesrF setdefaultrr makeprogressrrrrrupdaterjrr getancestorsKeyErrorr(completer _toposortrtrfilterrrrgcedrgetr/rr+r4rgetdeltarr)r textdiffr( datarepackedclose)(rr#targetr) maxchainlenbyfileentrycountrepackprogressrrC ancestors nohistory buildprogressrr orderednodesneworderednodesr2nobase referencedprocessprogress deltatuple deltabasechainlen ancestorinfop1p2linknodecopyfromr1 deltaentrydelta deltabasename origdeltabaser+r deltabasetextoriginalr0s( @r!rrepacker.repackdataMsK YY\\ll8^TB ^^**,EDI!!%.."5ejjA-  tyyF ) "( !7 H  ! !% (I2'22EIOO%&XSZ,M%U+$$$Q' +$$((55$)6 ,  " " $  )B CDL9~!=IN   y 1 2 1<@L """$(D!'t}}< 8BB.2 * #**40) / JUFJJE oo%&XS=N.O%\2&&q)(^^D$7 %*.))*:*:AxI(, (8(8!'> :-#11,  %\2&0&6# 8  0 00!%!3!3H!CJ@J=E=-88I$9$9:D%1(I5<(, h (J #'99==#@"8} %}h G IIMM(9Eu:D99,,X  $ $ & QJEU"8X ! F #u +$$T** +s )V22WWc 4URRn0nURR5H>nUR(dMXTR UR 05UR'M@ UR[S5UR[U5S9n[UR55GH:upx0n [SU55n U H3n X;aM U RUR R#X{U S95 M5 [%UR'U 55n [)5n U Hn XupnnX;aaX;a\XRR*:waUU:waU R-U5 XRR*:waU R-U5 MqU(aU R-U5 UR-X{XUU5 X;dMSXlM UR15 GM= UR35 UR5US9 g)Nsrepacking historyr7c3$# UHov M g7frWrr:s r!rf)repacker.repackhistory..r<r=r>TrB)r/r)rCrDrGrErrrFrrrrrrjrGrrHrrKrr/rhistoryrepacked incrementrJrR)rr#rSr)rUrVprogressrrCrYr0rr\ dontprocessrerfrgrhs r!rrepacker.repackhistorys YY\\^^**,E"""DI!!%.."5ejjA-?? " #$))3v;# "( !7 HI2'22E$  LL--hI-N$DNN9$=>L%K$-6_*(&4+>YY---(h2F#+YY---#+OOB' 828XF?48GM15%8    Y"8\  F #r cb^^UU4Sjn[R"TR5U5nU$)Nc>TUupp4/nUTRR:waURU5 UTRR:waURU5 U$rW)r/r/r()rrerfrgrhparentsrYrs r! parentfunc&repacker._toposort..parentfunc&sW)24 &BHGTYY%%%r"TYY%%%r"Nr )r sortnodeskeys)rrYr{ sortednodess`` r!rKrepacker._toposort%s) "++INN,0Ul0Ul[5UlgrW)rCrrcreated)rs r!rrepackledger.__init__9s  u r cURX#5nSUlURRU5nU(d[ 5nXPRU'UR U5 g)zPMark the given filename+node revision as having a data rev in the given source. TN)_getorcreateentryrFrrNrrrr$rrrVrCs r! markdataentryrepackledger.markdataentry>sR&&x6,,""6*eG#*LL  Er cURX#5nSUlURRU5nU(d[ 5nXPRU'UR U5 g)zSMark the given filename+node revision as having a history rev in the given source. TN)rrGrrNrrrs r!markhistoryentryrepackledger.markhistoryentryJsR&&x6",,""6*eG#*LL  Er cX4nURRU5nU(d[X5nX@RU'U$rW)rCrN repackentry)rrrrvalues r!rrepackledger._getorcreateentryVs<   %/E %LL  r c:URRU5 grW)rr)rrs r! addcreatedrepackledger.addcreated_s r )rrCrN) rrrrrrrrrrrrr r!rr3s     r rc"\rSrSrSrSrSrSrg)riczFSimple class representing a single revision entry in the repackledger.rrrFrGrQrsrMcbXlX lSUlSUlSUlSUlSUlg)NFr)rrrs r!rrepackentry.__init__ps2  "!$ r )rQrFrrMrsrGrN)rrrrr __slots__rrrr r!rrcsPI r rc[US5(a;[R"U[R5n[ R "U5$UR $)Nname)r<rr@rrAr r[)r/sharedcachepaths r!rrsGtV&66 )-- ww''yyr )TFrW)FN)NN)0 __future__rrarmercurial.i18nrmercurial.noder mercurialrrrrr r r r r mercurial.utilsrrrrrrr importmodrAbortrr5rQrUrDrnrrTrrrrrBr rrrrrr r!rs"     %   ( # 5;; N"5 p) X& OL ;|4*42";~HL)X7t~~B - - `8 r