;dZddlZddlZddlZddlmZddlmZddlm Z m Z ddl m Z m Z mZmZmZmZmZddlmZmZej*d Zej.Zej2Zej6Zej:Zd Zd Zd Z d Z!dZ"dZ#dZ$ejJZ%ejLZ&dZ'dZ(dZ)ee(Z*ee)Z+dZ,dZ-dZ.dZ/dZ0dZ1dZ2dZ3ee2Z4ee3Z5ee1Z6dZ7dZ8ee8Z9dZ:dZ;dZej~dAdZ@e'fd ZAd!e'fd"ZBej~d#ZCej~d$ZDej~d%ZEd&ZFGd'd(ZGd)ZHd*ZId+ZJd,ZKd-ZLd.ZMiZNd/ZOd0ZPd1ZQd2ZReOd3d4ZSeOd5d6ZTeOd7d8ZUeOd9d:ZVeOd;d<ZWeOd=d>ZXd?ZY dBd@ZZy)CaObsolete marker handling An obsolete marker maps an old changeset to a list of new changesets. If the list of new changesets is empty, the old changeset is said to be "killed". Otherwise, the old changeset is being "replaced" by the new changesets. Obsolete markers can be used to record and distribute changeset graph transformations performed by history rewrite operations, and help building new tools to reconcile conflicting rewrite actions. To facilitate conflict resolution, markers include various annotations besides old and news changeset identifiers, such as creation date or author name. The old obsoleted changeset is called a "predecessor" and possible replacements are called "successors". Markers that used changeset X as a predecessor are called "successor markers of X" because they hold information about the successors of X. Markers that use changeset Y as a successors are call "predecessor markers of Y" because they hold information about the predecessors of Y. Examples: - When changeset A is replaced by changeset A', one marker is stored: (A, (A',)) - When changesets A and B are folded into a new changeset C, two markers are stored: (A, (C,)) and (B, (C,)) - When changeset A is simply "pruned" from the graph, a marker is created: (A, ()) - When changeset A is split into B and C, a single marker is used: (A, (B, C)) We use a single marker to distinguish the "split" case from the "divergence" case. If two independent operations rewrite the same changeset A in to A' and A'', we have an error case: divergent rewriting. We can detect it because two markers will be created independently: (A, (B,)) and (A, (C,)) Format ------ Markers are stored in an append-only file stored in '.hg/store/obsstore'. The file starts with a version header: - 1 unsigned byte: version number, starting at zero. The header is followed by the markers. Marker format depend of the version. See comment associated with each format for details. N)_)getattr)binhex)encodingerrorobsutilphasespolicypycompatutil)dateutilhashutilparsers createmarkerss allowunstablesallowdivergencesexchangecd|z}|jjd|}||S |jjddS#tjtf$rat |jj dd}d|vrYy|jjdd}|r|jd||vcYSwxYw)TReturns True if the given repository has the given obsolete option enabled. s evolution.%s experimentals evolutionsallTsevolution.createmarkersr) ui configboolr ConfigErrorAttributeErrorset configlistconfigadd)repooption configkey newconfigresults 6usr/lib/python3.12/site-packages/mercurial/obsolete.py_getoptionvaluer$ms &(I""?I>I ww!!/<@@   ~ .  TWW''FG V GGNN?4NO  JJ' (  sAAB=3B=<B=ct|t}|r1t|t}t|t}t|t}nd}d}d}t|t|t|t|iS)z5Returns dicts showing state of obsolescence features.F)r$createmarkersoptallowunstableoptallowdivergenceopt exchangeopt)rcreatemarkersvalue unstablevaluedivergencevalue exchangevalues r# getoptionsr.sm)/?@'.>? )$0BC'k:    ,-O]  ct||S)r)r.)rrs r# isenabledr1s d F ##r/s>BIB20ss20sc#K||kr|||tz}|tz }tt|\}}}}d}|r)t|z} |||| z}tt|z|}|| z }||||z} t | |k7r,t jtd|t | fz||z }t| } | jddjd\} } t| t| f} d}d| vr%| jdd| jddf}nd| vr| jddf}nd | vrd}|, td |D}|D]}t |d k7sd}ntt%| j'} |||| | |f||kryy#t$rd} YwxYw#t j"$rd}Y]wxYww) NsIparsing obsolete marker: metadata is too short, %d bytes expected, got %ddates0 0 )grsp2sp1p0c32K|]}t|ywN)r.0ps r# z"_fm0readmarkers..s81As) _fm0fsize_unpack _fm0fixed _fm0fnodesize_fm0nodelenr Abortr_fm0decodemetapopsplitfloatint ValueErrortuplebinasciiErrorsorteditems)dataoffstopcurnumsucmdsizeflagspresucssmetadatawhenoffsetdateparentsr;s r#_fm0readmarkersr_s *3y) y%,Y%<"s &AsS1W%C8f,c2D 1HCcFl+ x=F "++83x=) *  v !(+ #<<8>>tDLD&;F +D H ||E40(,,ud2KLG h ||E402G h G   888 A1v|"&! 012D%499g *8 D ">>  s[B0G3:F-A G9%F*F*$1GG F'$G&F''G*G?GGGc|\}}}}}}|tzrtjtdt |}|\}}d||fz|d<|,|sd|d<t |dD]\} } t | |d| z<t|}t|} tt| zz} | t|||g} | j|t| g| |zS)Ns-cannot handle sha256 with old obsstore formats%r %ir4r/r6rsp%i) usingsha256r rDrdict enumerater_fm0encodemetarCr@rBextend_pack)markerrWrXrVrZr]r^timetzir;rTformatrPs r#_fm0encodeonemarkerrls06-Cuhg {kk!LMNNH~HHD" D":-HW!HUOgq)DAq#&q6HVaZ *h'H YF (V+ ,F CM5# .DKK  $ ( **r/c |jD]'\}}d|vsd|vr tdd|vstddjt|Dcgc] }d|||fzc}Scc}w)zmReturn encoded metadata string to string mapping. Assume no ':' in key and no '' in both key and value.:s*':' and '' are forbidden in metadata key's#':' is forbidden in metadata value's%s:%s)rOrJjoinrN)metakeyvalueks r#rdrdsxjjl U 3;%3,KL L E>CD D # ::t E 1x1d1g,. E FFEsA+cpi}|jdD]}|s|jdd\}}|||<!|S)z8Return string to string dictionary from encoded version.rornr)rG)rPdlrrrss r#rErE"sA A ZZ  q)JCAcF Hr/s>IdhHBBBs32ssBBc# Kt}t}t}t}t}t }t } t} t} t} tjtj} ||kr|| z}| |||\}}}}}}}||zr|}|}n|}|}| |||||z\}||z }|dk(r ||z}|||f}n|||zz}| ||z|||}||k(r|}d}n(|dk(r ||z}|||f}n|||zz}| ||z|||}|| |zz}| d| |zz|||}g}tdt|dD]0}|||z}|||dzz}|j!||||||f|}2|||t#|||dzf|f||kryyw)Nr>r<)_fm1parentnonera_fm1nodesha1size_fm1nodesha256size _fm1nodesha1_fm1nodesha256_fm1metapairsize _fm1metapair _fm1fsizer?structStruct _fm1fixedunpackrangerCappendrK) rPrQrRnoneflagsha2flagsha1sizesha2sizesha1fmtsha2fmtmetasizemetafmtfsizerufixedo1tsecsrirVrTnumparnummetanodefmtnodesizepreco2rXo3r^ metapairsizerZidxs r#_fm1purereadmarkersrZsHHH!HGGHG E F]]9 % , ,F * 5[6Dh''B'F*DBK8D X BG q[hBBr{nGh''BWv-tBr{;G8g%%dg&78$r#,G C -q1C|C((Bl37++B OOT#b\42;7 8C 2 T5%/D"r'?GLLY *s E>FFc (|\}}}}}}t}|tzrt}t|}d|z} |t} nt|} | | z } || z} t t|z} t | z| z} |ddz}d|d|||| t||g}|j|||j|t| }|D]\}}t|}t|}|dkDrd||fz}tj||dkDrd|||fz}tj||j||j||||zz }||d<t| g|g}|D]'\}}|j||j|)dj|S)Nrr|rsLobsstore metadata key cannot be longer than 255 bytes (key "%s" is %u bytes)s]obsstore metadata value cannot be longer than 255 bytes (value "%s" for key "%s" is %u bytes)r/)rrarrCr}rrre _calcsizer ProgrammingErrorrrfrp)rgrWrXrVrZr]r^_fm1noderT numextranodesr formatnodes formatmetarkrirP totalsizerrrslklvmsgs r#_fm1encodeonemarkerrs06-CuhgH {! YFJMW ]*KH -J  $z 1F aBB $q'2uffc(mS IDKK G&!I U X Z 8+b C((- - 8:R !C((- - B BR"W #$DG & 4 !D U C E 88D>r/cVttdd}|s t|||S||||S)Nfm1readmarkers)rrr)rPrQrRnatives r#_fm1readmarkersrs2 W. 5F "4d33 $T ""r/c&td|dddS)N>Brr)r?)rPs r#_readmarkerversionrs 5$q) $Q ''r/ct|}|sd}| t|}|tvr%td|z}t j |||t|d|||fS)z(Read and enumerate markers from raw datars+parsing obsolete marker: unknown version %rversionr)rrCformatsrr UnknownVersion)rPrQrR diskversionrs r# _readmarkersrsm%T*K  |4y'!>?+M""3 <<  ,Q/c4@ @@r/ctd|S)Nr)rfrs r# encodeheaderrs   r/Fc#dKt|d}|r t||D] }||ywNr)rr)markers addheaderr encodeonergs r# encodemarkersrs: #I7##s.0cj|D].}|j|dtj|0y)Nr setdefaultrr) successorsrmarks r#_addsuccessorsrs-d1gsu-11$7r/cx|D]5}|dD]+}|j|tj|-7yrr) predecessorsrrsucs r#_addpredecessorsrs77C  # #C / 3 3D 9r/c|D]:}|d}| |D]+}|j|tj|-<y)Nr)childrenrrr^r;s r# _addchildrenrsBq'  ##Asu-11$7r/cp|D]1}|j|dvstjtdy)zsearch for marker with invalid data and raise error if needed Exist as a separated function to allow the evolve extension for a more subtle handling. rs;bad obsolescence marker detected: invalid successors nullidN)nullidr rDr)rrrs r#_checkinvalidmarkersrs<  ;;$q' !++1 r/ceZdZdZdZedfdZedZdZ dZ dZ e Z ed Z dd Zd Zd ZedZedZedZedZedZedZdZdZdZy )obsstoreaStore obsolete markers Markers can be accessed with two mappings: - predecessors[x] -> set(markers on predecessors edges of x) - successors[x] -> set(markers on successors edges of x) - children[x] -> set(markers on predecessors edges of children(x) )sprecssuccssflagsmetar4sparentsFcpi|_||_tj||_||_||_yr8)cachessvfsweakrefref_repo_defaultformat _readonly)selfrr defaultformatreadonlys r#__init__zobsstore.__init__1s/  [[& +!r/cX|j}|d}tj||S)Nz(using the obsstore of a deallocated repo)rr r)rrrs r#rz obsstore.repo9s- JJL 9> DII %  s'B BBc|jS)zgTrue if marker creation is disabled Remove me in the future when obsolete marker is always on.)rrs r#rzobsstore.readonlyYs ~~r/Nc t|}|i}|hd|vr%tj|jd}n?|)|j dd}|)tj }ntj }|t zr:t|dk7r t||D]} t| dk7st| n9t|dk7r t||D]} t| dk7st| ||vrtd|jztt|j}|D](\} } | jd| jd*t'|t|||||f} t)|j+|| gS#t$rAtj dt#j$| t#j$| fzwxYw) a~obsolete: add a new obsolete marker * ensuring it is hashable * check mandatory metadata * encode metadata If you are a human writing code creating marker you want to use the `createmarkers` function in this module instead. return True if a new marker have been added, False if the markers already existed (no op). r4devels default-date r=zin-marker cycle with %szutf-8sEobsstore metadata must be valid UTF-8 sequence (key = %r, value = %r))rIr parsedaterF configdatemakedaterarCrJrrKrNrOdecodeUnicodeDecodeErrorr rr bytestrbytesrr) r transactionrsuccsflagr^r]rZrsuccrtvrgs r#createzobsstore.create`s.4y  H <("))(,,w*?@}}X?<#,,.D((* + 4yB &&t9?$T**4yB &&t9?$T** 5=6CD D 012DAq !! +uU|T8T7KDHH[6(344& ,,.''*H,<,>++JK ++ A adB//AUN !  1   +u-A  V4xx c6Q; NO  &..22=AL'##C(   S$ ' KK   {++//0A4HI278c#h;N2O ./3x s AF33GcBt|\}}|j||S)zfmerge a binary stream of markers inside the obsstore Returns the number of new markers added.)rr)rrrPrrs r# mergemarkerszobsstore.mergemarkerss$(-xx W--r/c8|jjdS)Nr)rtryreadrs r#rzobsstore._datasyy  --r/ctt|jdk\rt|jS|jSr)rCrrrrs r#rzobsstore._versions- tzz?a %djj1 1&& &r/c|j}|sgSt|\|_}t|}t |j ||Sr8)rrrlistrr)rrPrs r#rz obsstore._alls@zzI!-d!3 ww-TYY0r/c6i}t||j|Sr8)rr)rrs r#rzobsstore.successorss z499-r/c6i}t||j|Sr8)rr)rrs r#rzobsstore.predecessorss tyy1r/c6i}t||j|Sr8)rr)rrs r#rzobsstore.childrensXtyy)r/c||jvSr8)__dict__)rattrs r#rzobsstore._cachedst}}$$r/ct|}|j|z|_|jj||j drt |j ||j drt|j||j drt|j|t|j|y)Nrrr) r%rrrerrrrrrrrr)rrrawdatas r#rzobsstore._addmarkerssw-ZZ')  ! << % 4??G 4 << ' T.. 8 << #  0TYY0r/c>t|}t}t|}|j}|j}|j}|rt}|D]} |j |j | d|j | dD cgc] } | dr |  } } |j | |j | dD cgc] } | dr |  } } |j | ||z}|D chc]} | d }} ||z}||z}||z}|r|Scc} wcc} wcc} w)aqreturn a set of all obsolescence markers relevant to a set of nodes. "relevant" to a set of nodes mean: - marker that use this changeset as successor - prune marker of direct children on this changeset - recursive application of the two rules on predecessors of these markers It is a set so you cannot rely on order.r3rr)rrrrrr) rnodes pendingnodes seenmarkers seennodesprecursorsmarkers succsmarkersrdirectcurrentrpruneds r#relevantmarkerszobsstore.relevantmarkerss/5z e  %  -- ==UF' /33GR@A%-\\'2%>K%>ad!%>K f%%1%5%5gr%BO%B!A$!%BO f% ( k !F*01&QAaD&L1 6 !K I %L  %ILO2s DD D D. D)r3rNNNN)__name__ __module__ __qualname____doc__fields _fm1versionrpropertyrrrr__bool__rr rr  propertycacherrrrrrrrr8r3r/r#rrsHF2=u" H    A5F%N...''    % 1r/rc|jdd}i}|||d<t|t }t||jfd|i|}|r1|r/|j t dtt|z|S)z(Create an obsstore instance from a repo.sformatsobsstore-versionrrs3obsolete feature not enabled but %i markers found! ) configintr1r&rrwarnrrCr%)rrrkwargsrstores r# makestorerG)sLL,?@M F "/T#344H T499 Bx B6 BE   E F$u+   Lr/cN|jd|D]}|tvs |cSy)z|Return the newest version listed in both versions and our local formats. Returns None if no common version exists. T)reverseN)sortr)versionsr s r# commonversionrL<s-  MM$M  <H r/ici}g}tdz}|D]V}t|}t||ztkDrg}d}|j|j||t|z }Xt t |D]C\}}dj tdtg|z} tj| |d|z<E|S)zencode markers into a dict suitable for pushkey exchange - binary data is base85 encoded - split in chunks smaller than 5300 bytesr{rr/rsdump%i) _maxpayloadrlrCrrcreversedrprf _fm0versionr b85encode) rkeysparts currentlenrgnextdata currentpartrpartrPs r#_pushkeyescaperXPs D EqJ&v. x=: % 3KJ LL %8$c(m# x/ Txxuk23d:; $t 4Y_0 Kr/cZ|jsiStt|jS)zList markers over pushkey)rrXrNrs r# listmarkersr[fs" == &/ 00r/c|jds(|jjtd|zy|r(|jjtd|zyt j |}|j 5|jd5}|jj|||j ddddddy#1swYnxYwdddy#1swYyxYw)zPush markers over pushkeysdumpsunknown key: %rFsunexpected old value for %rspushkey: obsolete markersNT) startswithrrDrr b85decodelockrrr invalidatevolatilesets)rrroldrrPtrs r# pushmarkerrcms >>' "  Q)*S01   Q56<= >># D d&&'CD ""2t, ##%EDDs$ C/.C C/C# C//C8cfd}|S)zADecorator to register a function as computing the cache for a setcptvr#d}tj|tfz|t<|S)Ns;duplicated registration for volatileset '%s' (existing: %r)) cachefuncsr r)funcrnames r# decoratorzcachefor..decorators? : PC((j6F/G)GH H 4 r/r3)rhris` r#cacheforrjs r/cd|j}tjd|5|jst cdddS||jj vr%t |||jj |<|jj |cdddS#1swYyxYw)zyReturn the set of revision that belong to the set Such access may compute the set and cache it for future usez getrevs %sN) unfilteredrtimedcmr frozensetrrf)rrhs r#getrevsros ?? D lD )}}; * ) t}}++ +)3D)9$)?DMM  &}}##D) * ) )sB&AB&&B/cjd|jvr%|jjjyy)zRemove all obsolescence related cache from a repo This remove all cache in obsstore is the obsstore already exist on the repo. (We could be smarter here given the exact event that trigger the cache clearing)rN) _filecacherrrrZs r#clearobscachesrrs+doo% ""$&r/cV|jj|tjS)z-the set of mutable revision in the repository) _phasecache getrevsetr mutablephasesrZs r# _mutablerevsrws!    % %dF,@,@ AAr/obsoletec|jjt|}|jjj t fd|DS)zthe set of obsolete revisionsc3@K|]}|s|ywr8r3)r:rgetnodeisobss r#r<z&_computeobsoleteset..s? 1U71:->Q s) changelognoderwrr __contains__rn)r notpublicr{r|s @@r#_computeobsoletesetrsDnn!!GT"I MM $ $ 1 1E ? ? ??r/orphanc|jj}t|}t|d}||z }t }t |D]*}||D]}||vs||vs |j |*,t|S)z7the set of non obsolete revisions with obsolete parentsrx)r} parentrevsrwrorrNrrn)rpfuncmutableobsoleteothersunstablerr;s r#_computeorphansetrs NN % %E4 Gt[)H x FuH F^qAH}X  Q X r/ suspendedc|jjt|dtfdt|dDS)z9the set of obsolete parents with non obsolete descendantsrc3,K|] }|vs| ywr8r3)r:r suspendeds r#r<z'_computesuspendedset..sM :1a9nQ :s rx)r} ancestorsrorn)rrs @r#_computesuspendedsetrs8((y)ABI Mk :M MMr/sextinctc4t|dt|dz S)z must be an iterable of ((,...), (, ...)[,{metadata}]) tuple. `old` and `news` are changectx. metadata is an optional dictionary containing metadata for this marker only. It is merged with the global metadata specified through the `metadata` argument of this function. Any string values in metadata must be UTF-8 bytes. Trying to obsolete a public changeset will raise an exception. Current user and date are used except if specified otherwise in the metadata attribute. This function operates within a transaction of its own, but does not take any lock on the repo. Nsuserrsuser.obsmarkerrsevolution.track-operations operationsevolution.effect-flagssadd-obsolescence-markerrrs/Fold markers can only have 1 successors, not %dr{sfold-idr sfold-idxs fold-sizes$cannot obsolete public changeset: %ss see 'hg help phases' for details)hintc3<K|]}|jywr8r~)r:rYs r#r<z createmarkers..`s51affhc3<K|]}|jywr8rr9s r#r<z createmarkers..cs!CNq!&&(Nrs#changeset %s cannot obsolete itself)r^r]rZr)rrusernamer fromlocalrrrrKrCr rrrccopyrrrDrr~r^r geteffectflagEFFECTFLAGFIELDrrr filteredrevcacher)r relationsrr]rZ operationluser useoperationsaveeffectflagrb markerargsrelrrfoldidfoldsizefoldidxrrX localmetadatanprecnsucsnpare effectflagargss r# createmarkersrs(h GGNN8%6 7 M477;K;K;M %..u577%%5L !*WW''2N   4 5 Cq6LlE2 , < 1$SV)9H,,S3s1v;->??F<(H8|#C'):;!*<!; 1v (  s8a<!((Q0%06M*-16M+.27(2BM,/||~++ABTI@ 555!!CDLLN!CCEE>++@ADH "")!6!6tT!BJ=BZ=OM'"9"9: !!5% "FGI"<dD15 .E5% MM &77 !   ! ! ' ' )i 6 5 5s +H$KK")NN)rNNN)[r<rLrri18nrr rr~rrrrr r r r rutilsrr importmodrpackrfrr?calcsizerrAr&r'r(r)r$r.r1rrarPr@rBr>rAr_rlrdrEr>rrrr~rrr}rrrrrrrnogcrrrrrrrrrGrLrNrXr[rcrfrjrorrrwrrrrrrrrr3r/r#rs<|  &  9 %  -- OO "" $#'  <.$    !! ,   i (# 5:p+* G X   \*~. i  \*<M~.b#/#67/#67  ( A  A%!&+K 8 8 : : 8 8  GGT& " ,1     *& %B  +@@ )" ,NN  *DD  2   4(BFh*r/