ifI@ddlmZddlmZmZddlmZddlmZm Z m Z m Z m Z ddl mZmZddlmZmZddiZd Zd Zd Zd Zd Zej4GddZGddZGdde jZy))_)binhex)attr)encodingerrormetadatapycompatrevlog)dateutil stringutil) constantsflagutilbranchdefaultc|jddjddjdd}|jddS) aA >>> from .pycompat import bytechr as chr >>> d = {b'nl': chr(10), b'bs': chr(92), b'cr': chr(13), b'nul': chr(0)} >>> s = b"ab%(nl)scd%(bs)s%(bs)sn%(nul)s12ab%(cr)scd%(bs)s%(nl)s" % d >>> s 'ab\ncd\\\\n\x0012ab\rcd\\\n' >>> res = _string_escape(s) >>> s == _string_unescape(res) True \\\ s\n s\r\0)replacetexts 5/usr/lib/python3/dist-packages/mercurial/changelog.py_string_escaper#sB UG$     <<v &&cd|vr6|jdd}|jdd}|jdd}tj|S)Nrrs\\ rrr)rr unescapestrrs r_string_unescaper!7sJ ~||GY/||FE*||E3'  ! !$ ''rctj}|jdD](}|st|jdd\}}|||<*|S)a >>> from .pycompat import bytechr as chr >>> sorted(decodeextra(encodeextra({b'foo': b'bar', b'baz': chr(0) + b'2'}) ... ).items()) [('baz', '\x002'), ('branch', 'default'), ('foo', 'bar')] >>> sorted(decodeextra(encodeextra({b'foo': b'bar', ... b'baz': chr(92) + chr(0) + b'2'}) ... ).items()) [('baz', '\\\x002'), ('branch', 'default'), ('foo', 'bar')] r:r) _defaultextracopysplitr!)rextralkvs r decodeextrar+@sX    E ZZ  #A&,,T15DAqE!H Lrc t|Dcgc]}td|||fz}}dj|Scc}w)Ns%s:%sr)sortedrjoin)dr)itemss r encodeextrar1Ss@;A!9 Ea^H1Q4y0 1 EE E ::e  Fs;cdj|jDcgc]}|jc}jdScc}w)z>strip trailing whitespace and leading and trailing empty linesr)r. splitlinesrstripstrip)descr(s r stripdescr7Ys7 ::4??+<=aqxxz= > D DU KK=sA ceZdZejZejZejdZejdZejeje Z ejdZ ejdZ ejdZejdZejdZejeddfZy)_changelogrevisionr)default)r;NrF)__name__ __module__ __qualname__ribr'manifestuserdateFactorylistfiles filesadded filesremovedp1copiesp2copies descriptionr$ branchinforrr9r9^s DGGIEtwwyH 4773 D 4776 "D DGGLDLL. /E&J4774(Ltwwt$Htwwt$H$''#&K- ":E!BCJrr9ceZdZdZdZfdZedZedZedZ edZ edZ ed Z ed Z ed Zed Zed ZedZedZedZedZxZS)changelogrevisionzHolds results of a parsed changelog revision. Changelog revisions consist of multiple pieces of data, including the manifest node, user, and date. This object exposes a view into the parsed object. )_offsets_text _sidedata_cpsd_changescx|stt|jStt||}|j d}|j d|dz}|j d|dz}||dz|dzdk(r|} n|j d|dz} |||| f|_||_||_ ||_ d|_ |S)N)r'r@rr ) r9r$nullidsuperrN__new__indexrOrPrQrRrS) clsclrsidedatacpsdselfnl1nl2nl3doublenl __class__s rrYzchangelogrevision.__new__s%MBIIN N&4S9jjjja(jja( a#' "e +Hzz'373Hc31  !   rcLt|jd|jdS)Nr;)rrPrOr_s rr@zchangelogrevision.manifests!4::a$--"2344rcp|j}tj|j|ddz|dSNr;r)rOrtolocalrPr_offs rrAzchangelogrevision.users3mm 3q6A:A ?@@rct|j}|j|ddz|d}|jddddS)NrrU r;)rOrPr&)r_rk dateextras r_rawdatezchangelogrevision._rawdates?mmJJs1vzCF3 tQ'!,,rc|j}|j|ddz|d}|jdd}t|dk7ry|dS)NrrUrm)rOrPr&len)r_rkrnfieldss r _rawextrazchangelogrevision._rawextrasPmmJJs1vzCF3 q) v;! ayrc|j}t|d} t|d}||fS#t$rd}Y||fSwxYwrh)rofloatint ValueError)r_rawtimetimezones rrBzchangelogrevision.datesVmmSV} 3q6{HX~ HX~ s . ??c@|j}|tSt|SN)rtr$r+)r_rys rr'zchangelogrevision.extras!nn ; 3rc\|j |jS|jr tj|j}n`tj |j xsd|jxsd|jxsd|jxsi|jxsi}||_|S)NrL)touchedaddedremoved p1_copies p2_copies) rSrRr decode_files_sidedatarQ ChangingFilesrErFrGrHrI)r_changess rrzchangelogrevision.changess == $== ::44T^^DG,, (boo+))/R---2---2 G  rc|jrt|jjS|j}|d|dk(rgS|j |ddz|dj dS)NrUrqrr)rRr-rrrOrPr&rjs rrEzchangelogrevision.filessd ::$,,../ /mm q6SV Izz#a&1*s1v.44U;;rc|jr|jjS|jj d}|yt j |j|S)Ns filesadded)rRrrr'getr decodefileindicesrEr_ rawindicess rrFzchangelogrevision.filesaddedsK ::<<%% % 6J  ))$**jAArc|jr|jjS|jj d}|yt j |j|S)Ns filesremoved)rRrrr'rr rrErs rrGzchangelogrevision.filesremovedsK ::<<'' '8J  ))$**jAArc|jr|jjS|jj d}|yt j |j|S)Nsp1copies)rRrcopied_from_p1r'rr decodecopiesrEr_ rawcopiess rrHzchangelogrevision.p1copiesK ::<<.. . {3I  $$TZZ;;rc|jr|jjS|jj d}|yt j |j|S)Nsp2copies)rRrcopied_from_p2r'rr rrErs rrIzchangelogrevision.p2copies rrcftj|j|jddzdS)NrqrU)rrirPrOrfs rrJzchangelogrevision.descriptions- 4==+;a+?+A BCCrcj|j}tj|jdd|vfS)Nrsclose)r'rrir)r_r's rrKzchangelogrevision.branchinfos/  ) 45x57HHHr)r<r=r>__doc__ __slots__rYpropertyr@rArortrBr'rrErFrGrHrIrJrK __classcell__rds@rrNrNos7I$L55AA--      <<BBBB<<<<DDIIrrNceZdZddZedZej dZfdZdZdZ dZ dZ d Z d Z d Z dd Zd ZdZxZS) changelogc tjj||tjdfddd|jj dd||d |j rR|jtjk(r5|xjtjzc_ d|j_ d|_ d|_t|_i|_|jj d|_y)aVLoad a changelog revlog using an opener. If ``trypending`` is true, we attempt to load the index from a ``00changelog.i.a`` file instead of the default ``00changelog.i``. The ``00changelog.i.a`` file contains index (and possibly inline revision) data for a transaction that hasn't been finalized yet. It exists in a separate file to facilitate readers (such as hooks processes) accessing data before a transaction is finalized. ``concurrencychecker`` will be passed to the revlog init function, see the documentation there. Ns 00changelogTspersistent-nodemapF)targetradix checkambigmmaplargeindexpersistentnodemapconcurrencychecker trypending may_inlinescopies-storage)r __init__revlog_constantsKIND_CHANGELOGoptionsr _initempty_format_versionREVLOGV1 _format_flagsFLAG_GENERALDELTA delta_config general_delta_storedeltachains _v2_delayed frozenset _filteredrevs_filteredrevs_hashcache_copiesstorage)r_openerrrs rrzchangelog.__init__ s    $33T: $nn001FN1!   ?? 4 4 G   6#;#;"; ; .3D   + "' &[')$$nn001BCrc|jSr})rrfs r filteredrevszchangelog.filteredrevsJs!!!rcDt|tsJ||_i|_yr}) isinstancerrr)r_vals rrzchangelog.filteredrevsNs$#y))) ')$rcF|jstt||yyr})rrXr _write_docket)r_trrds rrzchangelog._write_docketUs  )T 0 4 rc|jjrJ|jrJ|jr|j ||j d|_n4|jj}|||_|j||jdt|z|j|jdt|z|jy)z2delay visibility of index updates to other readersNTs 000-cl-%i)_inneris_open _may_inline_inline_enforceinlinesize_docketrdelay _indexfile registertmp addpendingid _writepending addfinalize _finalize)r_r new_indexs r delayupdatezchangelog.delayupdateYs;;&&&&#### <<  # #B ' << ##D  ))+I$"+y) lRX-t/A/AB |bh.?rc|jjrJ|j#|jj|d|_y|jj }||_|jrd}tj|y)zfinalize index updatesNFz,changelog should not be inline at that point) rrrwriterfinalize_pendingrrrProgrammingError)r_rnew_index_filemsgs rrzchangelog._finalizemst;;&&&& << # LL  r "$D ![[99;N,DO||D,,S11rc|jjrJ|jr&|jj|d}d|_|S|jj \}}|||_|j||S)zLcreate a file containing the unfinalized state for pretxnchangegroupT)pendingF)rrrrr write_pendingrr)r_r any_pendingrs rrzchangelog._writependingzs;;&&&& <<,,,,R,>K$D   &*[[%>%>%@ "I{$"+y)rc^|js!tjj||yyr}) is_delayingr r)r_rs rrzchangelog._enforceinlinesizes$ MM , ,T2 6 rc|j|}|j|}|jdk(}t||||}|j|j |j |j|j|jfS)aObtain data from a parsed changelog revision. Returns a 6-tuple of: - manifest node in binary - author/user as a localstr - date as a 2-tuple of (time, timezone) - list of files - commit message as a localstr - dict of extra metadata Unless you need to access all fields, consider calling ``changelogrevision`` instead, as it is faster for partial object access. changeset-sidedata) _revisiondatar]rrNr@rArBrErJr')r_ nodeorrevr/r]copy_sdcs rreadzchangelog.readsn   y )==+%%)>> dAx 9 AFFAFFAGGQ]]AGGLLrc||j|}|j|}t||||jdk(S)z6Obtain a ``changelogrevision`` for a node or revision.r)rr]rNr)r_rrr]s rrNzchangelog.changelogrevisionsB!!),==+ $$"5"59N"N  rc|j|}|sgS|jd}|d|jd}|ddS)zX short version of read that only returns the files modified by the cset rVNrrq)revisionrZr&)r_rrlastr(s r readfileszchangelog.readfilessI}}Y'Izz'" $K  e $u rc tj|tj|}}|j}|stjt dd|vr4tjt dt j|zt|}|rdtj|z} ndtjz} | r>| jd} | dvr| d=n%| dvr!tjt d| zt|j} d } d}|jd k(r4|j r| t"j$z} t'j(|}| rt+| } d | | fz} t-||| g| zd |gz}dj/|}|j1||t3||||| }|j5|S)Nsempty usernamersusername %r contains a newlines%d %dr)rr).snullstipsthe name '%s' is reservedr;rs%s %sr)r]flags)r fromlocalr5r StorageErrorrr bytestrr7r parsedatemakedaterr-rrhas_copies_inforREVIDX_HASCOPIESINFOr encode_files_sidedatar1rr. addrevisionrrnode)r_r@rEr6 transactionp1p2rArBr' parseddatebranch sortedfilesrr]r(rrevs raddz changelog.adds''-x/A/A$/Gdzz|$$Q'8%9: : D=$$34x7G7G7MM  !H$6$6t$<U]]+    "7 7$$66655errrsetterrrrrrrrNrrrKrrrs@rrrsz(DT""** 5@( 2 7M,  (:x6rrN)i18nrrrr thirdpartyrrrr r r utilsr r revlogutilsrrrr$rr!r+r1r7sr9rNrrLrrr s J' '((& L  D D D mImI`^ ^r