�
�Xc@@s�dd
lm
Z

ddlmZ
ddlmZmZ
def
d��YZdef
d��YZ	d	e	f
d
��YZ
de	f
d��YZd
e
f
d��YZd�Z
def
d��YZdS(i(
tabsolute_importi
(
t
_(terrortutiltfuturec
B@seZ
dZd
�ZRS(s'placeholder for a value to be set latercC@s1tj
|d
�r$tjd�
�
n|
|_dS(Ntvaluesfuture is already set(RtsafehasattrRt	RepoErrorR(tselfR((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pytsets


(t__name__t
__module__t__doc__R	(((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyRs

tbatcherc
B@s)eZ
dZd
�Zd�Zd�ZRS(s'
base class for batches of commands submittable in a single request

    All methods invoked on instances of this class are simply queued and
    return a a future for the result. Once you call submit(), all the queued
    calls are performed and the results set in their respective futures.
    c

C@s
g|_dS(
N(
tcalls(
R((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyt__init__!s
c@s��
fd
�}|S(Nc@s)t�}�
j
j�||
|f�

|S(
N(RRtappend(targstoptstresref(tnameR(s2/usr/lib/python2.7/dist-packages/mercurial/peer.pytcall$s
	

((RRR((RRs2/usr/lib/python2.7/dist-packages/mercurial/peer.pyt__getattr__#s
c


C@s
t��
dS(
N(
tNotImplementedError(
R((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pytsubmit)s
(R
RRRRR(((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyR
s
		titerbatcherc
B@seZ
d�Zd
�ZRS(c


C@s
t��
dS(
N(
R(
R((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyR.s
c


C@s
t��
dS(
N(
R(
R((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pytresults1s
(R
RRR(((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyR,s	t
localbatchc
B@s eZ
dZd
�Zd�ZRS(s"performs the queued calls directlycC@stj
|�

|
|_dS(
N(R
Rtlocal(RR((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyR6s


c
C@sFx?|jD]4\}
}}}|j
t|j|
�||��

q
WdS(
N(RR	tgetattrR(RRRRR((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyR9s

(R
RRRR(((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyR4s

	tlocaliterbatcherc
B@s#eZ
d�Zd
�Zd�ZRS(cC@s tt
|�j�
|
|_dS(
N(tsuperRRR(RR((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyR>s

c


C@sdS(
N((
R((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyRBsc
c@s>x7|jD],\}
}}}t
|j|
�||�V
q
WdS(
N(RRR(RRRRR((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyRFs

(R
RRRR(((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyR=s
		c
@s#�f
d
�}
t|
d��
|
S(s�annotation for batchable methods

    Such methods must implement a coroutine as follows:

    @batchable
    def sample(self, one, two=None):
        # Handle locally computable results first:
        if not one:
            yield "a local result", None
        # Build list of encoded arguments suitable for your wire protocol:
        encargs = [('one', encode(one),), ('two', encode(two),)]
        # Create future for injection of encoded result:
        encresref = future()
        # Return encoded arguments and future:
        yield encargs, encresref
        # Assuming the future to be filled with the result from the batched
        # request now. Decode it:
        yield decode(encresref.value)

    The decorator returns a function which wraps this coroutine as a plain
    method, but adds the original method as an attribute called "batchable",
    which is used by remotebatch to split the call into separate encoding and
    decoding phases.
    c@s[�||
�}t|�
\}}|s+|S|d
}|j
|j�j|��

t|�
S(Ni(tnextR	t
_submitonet	func_name(RRt	batchabletencargsorrest	encresrefR(
t
f(s2/usr/lib/python2.7/dist-packages/mercurial/peer.pytplaincs







R#(
tsetattr(R&R'((
R&s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyR#Js
tpeerrepositoryc
B@sPeZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	RS(c

C@s
t|�
S(
N(
R(
R((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pytbatchps
c

C@s
t|�
S(
s�Batch requests but allow iterating over the results.

        This is to allow interleaving responses with things like
        progress updates for clients.
        (
R(
R((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyt	iterbatchsscC@sX|j�}|
|krt
S|
d
}x+|D]#}|j|�
r-|t|�
Sq-WtS(s�tell whether repo supports named capability.
        return False if not supported.
        if boolean capability, return True.
        if string capability, return string.t
=(t
_capabilitiestTruet
startswithtlentFalse(RRtcapstname_eqtcap((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pytcapable{s








cC@s5|j|
�
s1t
jtd
�
||
f�
�
ndS(s9raise an exception if the given capability is not presents?cannot %s; remote repository does not support the %r capabilityN(R5RtCapabilityErrorR
(RRtpurpose((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyt
requirecap�s

	
c


C@sd
S(s#return peer as a localrepo, or NoneN(
tNone(
R((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyR�sc


C@s|S(
N((
R((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pytpeer�s
c


C@stS(
N(
R.(
R((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pytcanpush�s
c


C@sdS(
N((
R((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pytclose�s
(
R
RR*R+R5R8RR:R;R<(((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyR)ns							N(t
__future__Rti18nR
tRRtobjectRR
RRRR#R)(((s2/usr/lib/python2.7/dist-packages/mercurial/peer.pyt<module>	s
	
	$