File: //usr/lib/python2.7/dist-packages/mercurial/branchmap.pyc
ó
ÛXc @@ sJ d d l m Z d d l Z d d l Z d d l Z d d l m Z m Z m Z m Z d d l
m Z m Z m
Z
e j Z e j Z e j Z e j Z d „ Z d „ Z i d d 6d d 6d
d 6d d
6Z d „ Z d
„ Z d e f d „ ƒ YZ d Z d e Z d e Z d Z e e ƒ Z d Z d Z d Z d e! f d „ ƒ YZ" d S( i ( t absolute_importNi ( t bint hext nullidt nullrev( t encodingt errort scmutilc C@ s) d } | j r% d | | j f } n | S( s7 name of a branchcache file for a given repo or repoviews
cache/branch2s %s-%s( t
filtername( t repot filename( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyt _filename s c C@ se y8 | j t | ƒ ƒ } | j ƒ j d ƒ } | j ƒ Wn t t f k
rR d SXy‰| j d ƒ j d d ƒ } | d \ } } t | ƒ t
| ƒ } } d } t | ƒ d k rÅ t | d ƒ } n t d | d | d | ƒ } | j
| ƒ sþ t d ƒ ‚ n | j } xÑ | D]É } | s qn | j d d ƒ \ }
} } | d k rVt d
ƒ ‚ n t j | j ƒ ƒ } t |
ƒ }
| j |
ƒ sŸt d t |
ƒ ƒ ‚ n | j | g ƒ j |
ƒ | d k r| j j |
ƒ qqWWn‚ t k
rò‚ no t k
r`}
| j j rWd
} | j d k r6| d | j 7} n | d 7} | j j | |
ƒ n d } n X| S( Ns
i t i t tipnodet tiprevt filteredhashs tip differst ocs invalid branch states node %s does not existt cs invalid branchheads caches (%s)s : %s
( t vfsR t readt splitt closet IOErrort OSErrort Nonet popR t intt lent branchcachet validfort
ValueErrort changelogR t tolocalt stript hasnodeR t
setdefaultt appendt _closednodest addt KeyboardInterruptt Exceptiont uit debugflagR t debug( R t ft linest cachekeyt lastt lrevR t partialt clt lt nodet statet labelt instt msg( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyR & sT
t visiblet servedt immutablet basec @ sQ | j } | j } | j j | ƒ ‰ g } ˆ d k sF ˆ j | ƒ rÜ t | ƒ ‰ ˆ d k rÜ t j | ƒ } | d k r… t ƒ ‰ qÙ | j | ƒ } | j
ƒ j ƒ ‰ | j j | j } | j
‡ f d † | Dƒ ƒ qÜ n | j
| j d ˆ j d ƒ ƒ | r"ˆ j | | ƒ ˆ j | ƒ n ˆ j | ƒ s=t | ƒ ‚ ˆ | j | j <d S( Nc 3@ s$ | ] } | ˆ j k r | Vq d S( N( R ( t .0t r( R1 ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pys <genexpr>o s t starti ( R R t
_branchcachest getR R R t subsettableR t filteredt branchmapt copyt filteredrevst extendt revsR t updatet writet AssertionError( R R2 R RH t
subsetnamet subsett extrarevs( ( R1 s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyt updatecache_ s( # c
@ s g } g } xr | j ƒ D]d } | j | ƒ xN | D]F } ˆ j j | ƒ } ˆ j j | ƒ \ } } | r3 | j | ƒ q3 q3 Wq W| rt ‡ f d † | Dƒ ƒ } t | ˆ | j ƒ | d | ƒ}
xM d D]B } ˆ j | ƒ } |
j
| ƒ rÌ |
ˆ j | <|
j | ƒ PqÌ qÌ Wn d S( s Replace the branchmap cache for a repo with a branch mapping.
This is likely only called during clone with a branch map from a remote.
c 3@ s' | ] } t ˆ j j | ƒ ƒ Vq d S( N( R R t rev( R= R4 ( R ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pys <genexpr>ˆ s t closednodesR< R; R: N( R< R; R: (
t
itervaluesRG R RP t
branchinfoR$ t maxR R4 RC R R@ RJ (
R t bmt rbheadst closedt bheadst hR> t bR t rtiprevt cachet candidatet rview( ( R s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyt replacecachex s,
R c B@ sq e Z d Z d
e e d d d „ Z d „ Z d „ Z d „ Z e
d „ Z d „ Z d „ Z
d „ Z d „ Z RS( s/ A dict like object that hold branches heads cache.
This cache is used to avoid costly computations to determine all the
branch heads of a repo.
The cache is serialized on disk in the following format:
<tip hex node> <tip rev number> [optional filtered repo hex hash]
<branch head hex node> <open/closed state> <branch name>
<branch head hex node> <open/closed state> <branch name>
...
The first line is used to check if the cache is still valid. If the
branch cache is for a filtered repo view, an optional third hash is
included that hashes the hashes of all filtered revisions.
The open/closed state is represented by a single letter 'o' or 'c'.
This field can be used to avoid changelog reads when determining if a
branch head closes a branch or not.
c C@ sY t t | ƒ j | ƒ | | _ | | _ | | _ | d k rL t ƒ | _ n | | _ d S( N( t superR t __init__R
R R R t setR% ( t selft entriesR
R R RQ ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyRa ® s c C@ sW y> | j | j j | j ƒ k o< | j t j | | j ƒ k SWn t k
rR t SXd S( s¹ Is the cache content valid regarding a repo
- False when cached tipnode is unknown or if we detect a strip.
- True when cache is up to date or a subset of current repo.N( R
R R4 R R R t
IndexErrort False( Rc R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyR ¼ s
c C@ sP | d } t } x3 t | ƒ D]% } | | j k r | } t } Pq q W| | f S( sh Return tuple with last open head in heads and false,
otherwise return last closed head and true.iÿÿÿÿ( t Truet reversedR% Rf ( Rc t headst tipRW RY ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyt
_branchtipÈ s
c C@ s | j | | ƒ d S( s“ Return the tipmost open head on branch head, otherwise return the
tipmost closed head on branch.
Raise KeyError for unknown branch.i ( Rk ( Rc t branch( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyt branchtipÔ s c C@ s? | | } | s; g | D] } | | j k r | ^ q } n | S( N( R% ( Rc Rl RW Ri RY ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyt branchheadsÚ s
+c c@ s9 x2 | j ƒ D]$ \ } } | | f | j | ƒ Vq
Wd S( N( t iteritemsRk ( Rc t bnRi ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyt iterbranchesà s c C@ s" t | | j | j | j | j ƒ S( s- return an deep copy of the branchcache object( R R
R R R% ( Rc ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyRE ä s c
C@ sv y<| j t | ƒ d d t ƒ} t | j ƒ t | j ƒ g } | j d k rg | j t | j ƒ ƒ n | j
d j | ƒ d ƒ d } x‚ t | j
ƒ ƒ D]n \ } } x_ | D]W } | d 7} | | j k rÕ d } n d } | j
d t | ƒ | t j | ƒ f ƒ q Wqš W| j ƒ | j j d
d | j t | ƒ | ƒ Wn3 t t t j f k
rq} | j j d | ƒ n Xd S(
Nt wt
atomictempR s
i i R t os %s %s %s
R s2 wrote %s branch cache with %d labels and %d nodes
s couldn't write branch cache: %s
( R R Rg R R
t strR R R R$ RJ t joint sortedRo R% R t fromlocalR R) t logR R R R R t AbortR+ (
Rc R R, R. t nodecountR6 t nodesR4 R5 R7 ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyRJ é s,
c @ sr t j ƒ } | j ‰ i } | j ƒ j } x[ | D]S } | | ƒ \ } } | j | g ƒ j | ƒ | r1 | j j ˆ j | ƒ ƒ q1 q1 Wt ˆ j
ƒ ƒ } x | j ƒ D]û \ } }
| j | g ƒ } t ‡ f d † | Dƒ ƒ } |
j ƒ | j
|
ƒ | | }
|
r9t |
ƒ } t ˆ j |
| ƒ ƒ } | | 8} n t | ƒ } g | D] } ˆ j | ƒ ^ qL| | <| d } | | j k r§ ˆ j | ƒ | _ | | _ q§ q§ W| j | ƒ s*t | _ t | _ x` | j ƒ D]O } t ‡ f d † | Dƒ ƒ } | | j k rÔˆ j | ƒ | _ | | _ qÔqÔWn t j | | j ƒ | _ t j ƒ | } | j j d d | j | ƒ d S( sÙ Given a branchhead cache, self, that may have extra nodes or be
missing heads, and a generator of nodes that are strictly a superset of
heads missing, this function updates self to be correct.
c 3@ s | ] } ˆ j | ƒ Vq d S( N( RP ( R= R4 ( R2 ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pys <genexpr> s iÿÿÿÿc 3@ s | ] } ˆ j | ƒ Vq d S( N( RP ( R= R4 ( R2 ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pys <genexpr>7 s R s( updated %s branch cache in %.4f seconds
N( t timeR t revbranchcacheRS R# R$ R% R& R4 Rb t headrevsRo t sortRI t mint ancestorsRw R R
R R R t valuesRT R R R) Ry R ( Rc R t revgent starttimet newbranchest
getbranchinfoR> Rl t closesbrancht topoheadst newheadrevsRX t bheadsett uncertaint floorrevR‚ t bheadrevsRP R Ri t duration( ( R2 s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyRI sL
&
( N( t __name__t
__module__t __doc__R R R Ra R Rk Rm Rf Rn Rq RE RJ RI ( ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyR ˜ s
s -v1s cache/rbc-namess cache/rbc-revss >4sIi iÿÿÿI € R~ c B@ sJ e Z d Z e d „ Z d „ Z d „ Z d „ Z d „ Z d d „ Z
RS( s™ Persistent cache, mapping from revision number to branch name and close.
This is a low level cache, independent of filtering.
Branch names are stored in rbc-names in internal encoding separated by 0.
rbc-names is append-only, and each branch name is only stored once and will
thus have a unique index.
The branch info for each revision is stored in rbc-revs as constant size
records. The whole file is read into memory, but it is only 'parsed' on
demand. The file is usually append-only but will be truncated if repo
modification is detected.
The record for each revision contains the first 4 bytes of the
corresponding node hash, and the record is only used if it still matches.
Even a completely trashed rbc-revs fill thus still give the right result
while converging towards full recovery ... assuming no incorrectly matching
node hashes.
The record also contains 4 bytes where 31 bits contains the index of the
branch and the last bit indicate that it is a branch close commit.
The usage pattern for rbc-revs is thus somewhat similar to 00changelog.i
and will grow with it but be 1/8th of its size.
c C@ sž | j d k s t ‚ | | _ g | _ t d ƒ | _ d | _ yS | j j t
ƒ } t | ƒ | _ g | j d ƒ D] } t
j | ƒ ^ qs | _ Wn, t t f k
rÀ | rÁ | j | _ qÁ n X| j r#y& | j j t ƒ } | j j | ƒ Wq#t t f k
r } | j j d | ƒ q#Xn t t | j ƒ t t | j ƒ ƒ | _ | j d k rfg | _ n t | j ƒ | _ t d „ t | j ƒ Dƒ ƒ | _ d S( NR i s s( couldn't read revision branch cache: %s
c s@ s! | ] \ } } | | f Vq d S( N( ( R= R> RZ ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pys <genexpr> s ( R R RK t _repot _namest arrayt _rbcrevst
_rbcsnameslenR R t _rbcnamesR R R R R R t _branchinfoRS t
fromstringR) R+ R t _rbcrecsizeR t _rbcrevslent _rbcnamescountt dictt enumeratet
_namesreverse( Rc R t readonlyt bndataRp t dataR7 ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyRa d s2 2 c C@ si d | _ | j 2d | _ | j j ƒ t | j j ƒ | _ t d ƒ | _
| j
j d | j t ƒ d S( Ni R s (
R— R” R R t clearR R“ R Rœ R• R– Rš R› ( Rc ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyt _clearƒ s
c C@ s` | j j } | t } | t k r/ | j | ƒ St | j ƒ | t k rU | j | ƒ S| j | ƒ t } t
t t | j | t ƒ ƒ \ } } t
| t @ƒ } | r¯ | t M} n | d k r¾ n• | | k ry | j | | f SWqSt k
r| j j j d ƒ | j ƒ qSXn@ | j j j d | ƒ | t } | j | 3t | j | ƒ | _ | j | ƒ S( sW Return branch name and close flag for rev, using and updating
persistent cache.s sR referenced branch names not found - rebuilding revision branch cache from scratch
sP history modification detected - truncating revision branch cache to revision %s
( R“ R R› R RS R R– R™ R4 t _rbcnodelent unpackt
_rbcrecfmtt buffert boolt
_rbccloseflagt _rbcbranchidxmaskR” Re R) R+ R¥ R Rœ ( Rc RP R t rbcrevidxt reponodet cachenodet branchidxR t truncate( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyRS Œ s4
!
c C@ s« | j j } | j | ƒ \ } } | | j k r@ | j | } n, t | j ƒ } | j j | ƒ | | j | <| j | ƒ } | rŽ | t O} n | j | | | ƒ | | f S( s7 Retrieve branch info from changelog and update _rbcrevs(
R“ R RS R R R” R$ R4 R« t
_setcachedata( Rc RP R RZ R R° R® ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyR™ ¶ s
c C@ sÔ | t } t d ƒ } | j t t | | ƒ ƒ t | j ƒ | t k r| | j j d t | j j ƒ t t | j ƒ ƒ n | | j | | t +t
| j | ƒ | _ | j j ƒ } | rÐ | j
d | j ƒ n d S( s: Writes the node's branch data to the in-memory cache data.R s s write-revbranchcacheN( R› R• Rš t packR¨ R R– RG R“ R R Rœ t currenttransactiont addfinalizeRJ ( Rc RP R4 R° R t rect tr( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyR² Æ s
c
C@ sé | j } d
} d } z³ym| j t | j ƒ k r\d } | j d t ƒ } | j d k rÇ | j j t d ƒ } | j
ƒ | j k r” | j d ƒ qÇ | j
ƒ | j j d t ƒ d | _ d | _ n | j d k r| j j t d t ƒ| j j t d ƒ } n | j d j d
„ | j | j Dƒ ƒ ƒ | j
ƒ | _ | j
ƒ t | j ƒ | _ n | j t } | t | j ƒ k r„d } | d
k r¥| j d t ƒ } n t t | j ƒ t | j ƒ t ƒ } | j j t d ƒ } | j
ƒ | k rM| j j d t | f ƒ | j | ƒ | j
ƒ | k r@d } | j | ƒ n | j ƒ n | t } | j | j | | !ƒ | j
ƒ | | _ n Wn? t t t j t j f k
rÆ} | j j d | | f ƒ n XWd
| d
k rä| j ƒ n Xd
S( s! Save branch cache if it is dirty.t s namest waiti t abs s %s changed - rewriting it
t
ignoremissingt wbc s@ s | ] } t j | ƒ Vq d S( N( R Rx ( R= RZ ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pys <genexpr>ì s s truncating %s to %s
s+ couldn't write revision branch cache%s: %s
N( R“ R R R R” t wlockRf R t openR˜ t tellR— RJ R R) R+ Rœ t
unlinkpathR– Rg Rv R› R R t seekR± R R R Rz t LockErrort release(
Rc R· R R½ t stepR, R? RH t endR7 ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyRJ Ö s`
! N( R R‘ R’ Rg Ra R¥ RS R™ R² R RJ ( ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyR~ M s * (# t
__future__R R• t structR} R4 R R R R R¸ R R R t calcsizeR³ R§ R R R RB RO R_ Rž R t _rbcversionR˜ R– R¨ R› R¦ R¬ R« t objectR~ ( ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/branchmap.pyt <module> s6 " 4
«