^cD $ddlZddlZddlmZddlmZmZmZddlm Z m Z m Z ddl m Z ddlmZddlmZejejZd Zd Zejd Zd Zd ZdZdZdZdZddZ dZ!dZ"ddddde j#dddf dZ$dZ%dS)N)_)binnullrevsha1nodeconstants)dagoperrormdiff) repository)sidedata)hashutilcB|tjkr/t}||n8||kr|}|}n|}|}t j|}|||||S)zCompute the SHA-1 for revision data and its parents. This hash combines both the current file contents and its history in a manner that makes it easy to distinguish nodes with the same content in the revision graph. )rnullid _nullhashcopyupdater sha1digest)textp1p2sabs =/usr/lib/python3/dist-packages/mercurial/utils/storageutil.pyhashrevisionsha1r"s  %%% NN     77AAAAA M!    HHTNNN 88:: c |dddkrdSt|d}|d|}i}|D] }|dd\}}|||<!||dzfS)zParse metadata header from revision data. Returns a 2-tuple of (metadata, offset), where both can be None if there is no metadata. Nrr)NNs: r) METADATA_REsearchstart splitlinessplit)rrmtextmetalkvs r parsemetar+?s BQBx9z4##))++A 1IE D     wwua  1Q Q;rcrt}dfd|D}d||fzS)z2Add metadata to fulltext to produce revision text.rc32K|]}d||fzVdS)s%s: %s N).0r)r's r zpackmeta..Ts0AAq q$q'l2AAAAAArs %s %s)sortedjoin)r'rkeysmetatexts` rpackmetar5QsD $<r iscensoredrevrenamedread)r@rAfiledata revisiontextrr computednodes rfiledataequivalentrKs9%% &1  ]]4 FB#L"b99Ltt  $((3 }}T,zz$8++ 5rc\d}|||krd}||z }||kr|}n|}t|||S)z)Iterate over revision numbers in a store.rN)range)storelenr#stopsteps riterrevsrRsJ D  4<<D   (??D d # ##rct|trJ ||S#t$r't jd|z|t dwxYwt|dvr- |||S#tj$rYnwxYwt|dvr7 t|}|||S#t$rYnwxYw t|}d|z|krt ||S#ttf$rYnwxYwn#ttf$rYnwxYwt j||t d)aResolve the file node for a value. ``store`` is an object implementing the ``ifileindex`` interface. ``fileid`` can be: * A 20 or 32 byte binary node. * An integer revision number * A 40 or 64 byte hex node. * A bytes that can be parsed as an integer representing a revision number. ``identifier`` is used to populate ``error.LookupError`` with an identifier for the store. Raises ``error.LookupError`` on failure. s%dsno match found) )(@) isinstanceintrA IndexErrorr LookupErrorrlenrEr TypeError ValueError OverflowError)r@fileid identifierrawnoderEs r fileidlookuprcs"&# ::f%% %   # A.?,@,@    6{{h  IIf   M     D  6{{h &kkG IIg   N    D   &kk 3;&   ::c?? "I&    D    &       FJ2C0D0D E EEs],1A2B BB0%C C#"C#'D4DD0-D4/D00D44EEct}|dz}i}t}|D]-} || } | || <| |kr|| .|r|dz}||} | |kr||n|| ||D]8} | tkr+|| } | || <| |kr|| 9|||fS)aResolve information needed to strip revisions. Finds the minimum revision number that must be stripped in order to strip ``minlinkrev``. Returns a 2-tuple of the minimum revision number to do that and a set of all revision numbers that have linkrevs that would be broken by that strip. ``tiprev`` is the current tip-most revision. It is ``len(store) - 1``. ``headrevs`` is an iterable of head revisions. ``linkrevfn`` is a callable that receives a revision and returns a linked revision. ``parentrevsfn`` is a callable that receives a revision number and returns an iterable of its parent revision numbers. r)setaddpopremover) minlinkrevtiprevheadrevs linkrevfn parentrevsfn brokenrevs strippointheadsfuturelargelinkrevshead headlinkrevlinkrevpplinkrevs rresolvestripinforws1"J!J E%%11ioo !d * $ $  # #K 0 0 0 6a ))J'' Z   NN: & & & &  & &w / / /j)) 6 6AG||$9Q<<#az))'++H555 6 z !!rFc #"#$%K|j} |j$|j%|dkr$fd|D}nJ|dkr)$fd|D}tj||j}nt $fd|D}d}| t jks| r%|dd}t#t"| rGt%fd|D}| || |d ""#fd }|D]}|tkr| |}%|\}}|r ||}nt}| t jkr|}na| t j krt}nI| t j kr|}n6||r|}n(||r|}n||r|}n ||}nt}|tkr|r|||st}d}d}d}| rE||s||rv ||}n##t j$r}|j}Yd}~nd}~wwxYw|tkr0|r ||}nt'||}n|tkr;| t jkr+||}#|n_|r |||}n;t+j||||}#|d}d }| r_ ||}t1j|| || \}}n#t j$ri}YnwxYw|rt1j|}|r ||nd} d}!|r|!t6z}!| |d|dzz} ||| || || || |||||! V|}dS)a Generic implementation of ifiledata.emitrevisions(). Emitting revision data is subtly complex. This function attempts to encapsulate all the logic for doing so in a backend-agnostic way. ``store`` Object conforming to ``ifilestorage`` interface. ``nodes`` List of revision nodes whose data to emit. ``resultcls`` A type implementing the ``irevisiondelta`` interface that will be constructed and returned. ``deltaparentfn`` (optional) Callable receiving a revision number and returning the revision number of a revision that the internal delta is stored against. This delta will be preferred over computing a new arbitrary delta. If not defined, a delta will always be computed from raw revision data. ``candeltafn`` (optional) Callable receiving a pair of revision numbers that returns a bool indicating whether a delta between them can be produced. If not defined, it is assumed that any two revisions can delta with each other. ``rawsizefn`` (optional) Callable receiving a revision number and returning the length of the ``store.rawdata(rev)``. If not defined, ``len(store.rawdata(rev))`` will be called. ``revdifffn`` (optional) Callable receiving a pair of revision numbers that returns a delta between them. If not defined, a delta will be computed by invoking mdiff code on ``store.revision()`` results. Defining this function allows a precomputed or stored delta to be used without having to compute on. ``flagsfn`` (optional) Callable receiving a revision number and returns the integer flags value for it. If not defined, flags value will be 0. ``deltamode`` constaint on delta to be sent: * CG_DELTAMODE_STD - normal mode, try to reuse storage deltas, * CG_DELTAMODE_PREV - only delta against "prev", * CG_DELTAMODE_FULL - only issue full snapshot. Whether to send fulltext revisions instead of deltas, if allowed. ``nodesorder`` ``revisiondata`` ``assumehaveparentrevisions`` ``sidedata_helpers`` (optional) If not None, means that sidedata should be included. See `revlogutil.sidedata.get_sidedata_helpers`. snodesc&g|] }|Sr.r.r/nfrevs r z!emitrevisions..|!'''AQ'''rslinearc&h|] }|Sr.r.rzs r z emitrevisions..~r~rc3.K|]}|VdSNr.rzs rr0z emitrevisions..s+--!dd1gg------rNrc38K|]}|D]}|VdSrr.)r/rrur>s rr0z emitrevisions..s8??GGAJJ??q1???????rT) inclusivec.|tkrdS|vp|vS)z5Is a delta against this revision usable over the wireF)r)rE availableemitteds ris_usable_basez%emitrevisions..is_usable_bases% '>>5g~1 !11r)rr)r@sidedata_helpersr rEr) rAp1nodep2nodebasenodeflagsbaserevisionsizer?deltar protocol_flags)rArE parentrevsr linearizer1r CG_DELTAMODE_PREVredifference_update ancestorsrCG_DELTAMODE_FULLCG_DELTAMODE_P1rDrawdatar CensoredNodeError tombstoner\rfr textdiffr sidedatamodrun_sidedata_helpersserialize_sidedataCG_FLAG_SIDEDATA)&r@nodes nodesorder resultcls deltaparentfn candeltafn rawsizefn revdifffnflagsfn deltamode revisiondataassumehaveparentrevisionsrfnoderevsprevrev common_headsrrErAp1revp2revdeltaparentrevbaserevr?rreserialized_sidedatasidedata_flags old_sidedatar rrrrr|r>s& @@@@r emitrevisionsr&sIb JE 9DGX''''''' y '''''''tU%566----u-----GJ0004M0'$q'""1%eeGI B????d????? &&t,,,OOLDOAA 222222  '>> uSzzws|| u  %*]3//NN$N  4 4 4GG*6 6 6GG *4 4 4GG ^N + + "$GG~e$$ "&& "$!! g  : jj#6N6N G  !(( !E,<,=M>c$tjd}t||krdS||}t||z }|d|tj||krdSd}t|}||ko||||z|kS)aRDetermine if a delta represents censored revision data. ``baserev`` is the base revision this delta is encoded against. ``baselenfn`` is a callable receiving a revision number that resolves the length of the revision fulltext. Returns a bool indicating if the result of the delta represents a censored revision. s>lllFNs  censored:)structcalcsizer\r replacediffheader)rr baselenfnhlenoldlennewlenrfaddlens rdeltaiscensoredrs ?7 # #D 5zzTu Yw  F ZZ$ F UdU|u.vv>>>>u C XXF V  BdTF]&: ;s BBr)rN)&reri18nrrArrrrr r interfacesr revlogutilsr rutilsr rrrrrcompiler!r+r5r7r<rBrKrRrcrwCG_DELTAMODE_STDrrr.rrrs   $#####111111 HM+2 3 3 4bj## $222(((   6"""J $ $ $ $ 5F5F5Fp1"1"1"r )#oooodCCCCCr