�
�Xc@@s�dd
lm
Z

ddlmZ
ddlmZ
def
d��YZdef
d��YZd	ef
d
��YZ	de	f
d��YZ
d
e	efd��YZdS(i(
tabsolute_importi
(
t
_(
tnullrevtbasedagcB@s�eZ
dZd
�Zd�Zd�Zd�Zd�Zd
d�
Z	d
d�
Z
d�Zd	�Zd
�Z
d�Zed�
ZRS(s�generic interface for DAGs

    terms:
    "ix" (short for index) identifies a nodes internally,
    "id" identifies one externally.

    All params are ixs unless explicitly suffixed otherwise.
    Pluralized params are lists or sets.
    c

C@s
d|_
dS(
N(tNonet_inverse(
tself((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyt__init__s
c


C@s
t�
d
S(sset of all node ixsN(
tNotImplementedError(
R((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pytnodesetsc


C@s
t�
d
S(slist of head ixsN(
R(
R((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pytheads sc
C@s
t�
d
S(slist of parents ixs of ixN(
R(Rtix((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pytparents$sc


C@s
t�
d
S(s1inverse DAG, where parents becomes children, etc.N(
R(
R((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pytinverse(sc
C@s
t�
d
S(sV
        set of all ancestors of starts (incl), but stop walk at stops (excl)
        N(
R(Rtstartststops((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pytancestorset,scC@s|j�j
|
|�S(
sX
        set of all descendants of starts (incl), but stop walk at stops (excl)
        (R
R(RRR((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyt
descendantset2sc
C@s
t�
d
S(s�
        subset of connected list of ixs so that no node has a descendant in it

        By "connected list" we mean that if an ancestor and a descendant are in
        the list, then so is at least one path connecting them.
        N(
R(Rtixs((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pytheadsetofconnecteds8scC@s
|j|
�
S(
sreturn a node id(
t_externalize(RR((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pytexternalizeAscC@s2|j|
�
}t
|
t�r(t|�
St|�
S(
s4return a list of (or set if given a set) of node ids(t_externalizeallt
isinstancetsettlist(RRtids((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pytexternalizeallEs



cC@s
|j|
�
S(
sreturn a node ix(
t_internalize(Rtid((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pytinternalizeLscC@s5|j|
|�}t
|
t�r+t|�
St|�
S(
s4return a list of (or set if given a set) of node ixs(t_internalizeallRRR(RRt
filterunknownR((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pytinternalizeallPs



N(t__name__t
__module__t__doc__RR	R
RR
RRRRRRRtFalseR!(((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyRs											t
genericdagcB@s#eZ
dZdd
�
Zd�ZRS(s generic implementations for DAGscC@s�|rt|�
}n	t�}t�}t
|
�
}xT|r�|j�}||kr6||kr6|j|�

|j|j|�
�

q6q6W|S(
N(RRtpoptaddtextendR(RRRtseentpendingt
n((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR[s

	
	

	





cC@s^t|
�
}|s|Sx5|
D]-}x$|j
|�
D]}|j|�

q3WqW|sZt�
|S(
N(RRtdiscardtAssertionError(RRthdsR,t
p((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyRis








N(R"R#R$RRR(((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR&Xs
trevlogbaseddagc
B@sMeZ
dZd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	RS(s!generic dag interface to a revlogcC@s,tj
|�

|
|_d|_||_dS(
N(RRt_revlogRt_headst_nodeset(RtrevlogR	((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyRws


	
	
c


C@s|jS(
N(
R4(
R((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR	}s
c

C@s(|jdkr!|j�|_n|jS(
N(R3Rt	_getheads(
R((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR
�s


cC@s|jj
|
d
S(Ni(R2tindex(RR((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR�s
cC@s+|jj
}g|
D]}||d
^qS(Ni(R2R7(RRtidxt
i((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR�s

cC@sC|jj
|
�
}|tkr?t|
|jjtd
�
��
n|S(Ntnullid(R2trevRtLookupErrort	indexfileR
(RRR((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR�s


!
cC@sl|j}|r\gt
|jj|
�D]3}|dk	r%|tkr%||jkr%|^q%St
|j|
�S(
N(R2tmaptnodemaptgetRRtfilteredrevsR(RRR trlt
r((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR�s
	





(
R"R#R$RR	R
RRRR(((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR1ts
						t	revlogdagcB@sPeZ
dZd
�Zd�Zd�Zd�Zdd�
Zd�Z	d�Z
RS(	sdag interface to a revlogcC@stj
||
t|
�
�
dS(
N(R1RR(RR5((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR�s
c
C@s,g|jj
�D]}
|
tkr|
^qS(
N(R2theadrevsR(RRC((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR6�s
cC@sz|j}|j
}||
}|d
}|tkrY|d}|tkrO|g
S||gS|d}|tkrv|g
SgS(Nii(R2R7R(RRtrlogR8trevdatatprevtprev2((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR�s
	
	















c

C@s(|jdkr!t|�
|_n|jS(
N(RRtinverserevlogdag(
R((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR
�s


cC@s�|j}|j
}|r't|�
}n	t�}t�}t|
�
}x�|r�|j�}||krH||krH|j|�

||}x=d
dgD],}	||	}
|
tkr�|j|
�

q�q�WqHqHW|S(Nii(R2R7RRR'R(Rtappend(RRRRFR8R*R+R;RGR9RH((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR�s"
	
	

	
	

	











c	C@s�|
s
t�S|j
}|j}t|
�
}xU|
D]M}||}x:d
dgD],}||}|tkrO|j|�

qOqOWq2W|s�t�
|S(Nii(RR2R7RR-R.(	RRRFR8RER;RGR9RH((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR�s


	
	











cC@s
g}t|j
|
�
�
}|jd
t�

t�}x�|r�|j�}|dkr�|d}||kr�|j|�

|j|�

q�q7|j|d�

|g|j|�
D]$}||
kr�||kr�|^q�7}q7Wt	|�
t	|
�
ks�t
�
|S(s�
linearize and topologically sort a list of revisions

        The linearization process tries to create long runs of revs where
        a child rev comes immediately after its first parent. This is done by
        visiting the heads of the given revs in inverse topological order,
        and for each visited rev, visiting its second parent, then its first
        parent, then adding the rev itself to the output list.
        treverseii
(RRtsorttTrueRR'RKR(RtlenR.(RRtsortedtvisittfinishedtcurR0((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyt	linearize�s 	


		








)

N(R"R#R$RR6RR
RRRRT(((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyRD�s
					RJc
B@s;eZ
dZd
�Zd�Zd�Zd�Zd�ZRS(s:inverse of an existing revlog dag; see revlogdag.inverse()cC@sNtj
||
j|
j�
|
|_i|_g|_t|j�
d
|_dS(Ni
(	R1RR2R4t_origt	_childrent_rootsROt	_walkfrom(Rtorig((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR�s


	
	
	
c	C@s�|j}|j
}|j}|jj}x�||
kr�||}t}xJ|d
|dgD]4}|tkr[|j|g�j|�

t	}q[q[W|r�|j|�

n|d8}q*W||_dS(Niii
(
RXRVRWR2R7RNRt
setdefaultRKR%(	RtwalktoR;tcstrootsR8tdatatisrootRH((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyt_walkto

s
	
	
	













c

C@s|jt
�

|jS(
N(R`RRW(
R((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR6
s


cC@sB|
dkrgS|
|j
k
r/|j|
�

n|jj|
g�S(
N(RRXR`RVR@(RR((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR
s





c


C@s|jS(
N(
RU(
R((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyR

s
(R"R#R$RR`R6RR
(((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyRJ�s
				N(t
__future__Rti18nR
tnodeRtobjectRR&R1RDRJ(((s5/usr/lib/python2.7/dist-packages/mercurial/dagutil.pyt<module>	s
J&]