��c@s

dd
lm
Z

ddlmZ
ddlZddlZddlZddlZddlZddl	Z	ddl
Z
ddlZddlZddl
Z
ddlZddlZddlZddlZd�Zde
jf
d��YZdef
d��YZd	�ZdS(
i�(
tnullid(
t
_Nc
cs�tj
�}
yEx>tj|�D]-}x$|rK|
j|d�V
|
j}q(WqWWn)tjk
r|


tdt
d���n
X|
j�V
dS(Niisconnection ended unexpectedlyi(tzlibt
decompressobjtutilt
filechunkitert
decompresstunconsumed_tailthttplibt
HTTPExceptiontIOErrortNoneR
tflush(t
ftzdtchunk((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyt
zgenerators



	




thttppeerc
BskeZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�ZRS(cCs�||_d|_d|_d|_tj|�}|jsE|jrmtj	t
d
�|jpc|j��n|j�\|_}|
|_
|j
jd|j�
tj|
|�|_dS(Nsunsupported URL component: "%s"s	using %s
(tpathRtcapsthandlert	urlopenerRturltquerytfragmenttAbortR
tauthinfot_urltuitdebugtopener(tselfRRt
uR((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyt__init__s
	
	
	
	



	
c
CsG|jrCx7|jj
D]&}
|
j�
t|
d
d���
qWndS(Nt	close_allc
SsdS(
N(
R(((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyt<lambda>1s(Rthandlerstclosetgetattr(Rt
h((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyt__del__-s
	



c


Cs|jS(
N(
R(
R((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyR3s
c

Cs"t|j
d
�j��|_dS(Ntcapabilities(tsett_calltsplitR(
R((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyt
_fetchcaps8s
c

Css|jdkrly|j�
Wn tjk
r?


t�|_n
X|jjd
dj|jpadg
��
n|jS(Nscapabilities: %s
t
 tnone(	RRR-terrort	RepoErrorR*RRtjoin(
R((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyt
_capabilities;s






 
c

Cstj
td
���dS(Ns!operation not supported over http(RRR
(
R((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pytlockEs
cKs�|
d
krd|d<n|jdd�}d}tj|d�rO|j}n|dk	rjt|�}n|jdi�}|dk	r�d|kr�d|d<n|r�|jjd	d
t�r�d|d<d
|d<n|jj	d|
�
d|
fg
}d}t|�dkrE
|j
d�}|rE
t|jd�d�}qE
n|dkr(t
jt|j���}	d}
|t|
dd�}d}xOtdt|	�|�D]5}
|d7}|
t|�}|	|
|
|!||<q�Wgtd|d�D]}|
t|�^q�dj|�|d<n|t|j��7}dt
j|�}d|j|f}tj|||�}|dk	r�|jj	d|�
|jdd|�
ny|jj|�}Wn�tjk
r
}
|jdkrtjtd���n�nktj k
rM
}
|jj	d|
�
|jj!�
t"d|��n&t#k
rr


tjtd ���n
X|j$�}|j%|�r�|t|� }n|jj&d!�|j&d!�kr�jj's�jj(td"�|�
q�||_y|j)d#�}Wn&t*k
r3


|j+j,d#d�}n
Xtj-|j�}|j.d$�rmt/j0|j1���n|j.d%�p�|j.d&�r�|j+j,d'�p�|j.d(�s�jj	d)tj-|��
t/j2td*�||p�+|j1d,�f��n|j.d%�r�yH|jd-d�d}t3g|jd.�D]}t|�^q9�}Wn0t4k
r�


t/j2td/�||f��n
X|d1kr�t/j2td0�||f��q�n|S(2NtpushkeyttdataitlengththeaderssContent-Typesapplication/mercurial-0.1Rtusehttp2s100-ContinuetExpectt
1s	X-HgHttp2ssending %s command
tcmdt
httpheadert
,s
X-HgArg-%st000s: 
i
tVarys?%ss%s%sssending %s bytes
sContent-Lengths%di�sauthorization faileds$http error while sending %s command
s,http error, possibly caused by proxy settingt
/sreal URL is %s
scontent-typesapplication/hg-errorsapplication/mercurial-s
text/plainscontent-lengthsapplication/hg-changegroupsrequested URL: '%s'
sI'%s' does not appear to be an hg repository:
---%%<--- (%s)
%s
---%%<---
sno content-typeit
-t
.s+'%s' sent a broken Content-Type header (%s)s'%s' uses newer protocol %s(ii
(5tpopRRtsafehasattrR8tlenRt
configbooltFalseRtcapabletintR,turllibt	urlencodetsortedtitemstxrangetstrtrangeR2Rturllib2tRequesttadd_unredirected_headerRtopent	HTTPErrortcodeRR
RR	t	tracebackR
t
IndexErrortgeturltendswithtrstriptquiettwarnt	getheadertAttributeErrorR9tgetthidepasswordt
startswithR0tOutOfBandErrortreadR1ttuplet
ValueError(RR=targsR7tsizeR9t
qt
headersizeR>tencargst	headerfmtt
contentlent	headernumt
itheaderR'tvaryheaderstqstcutreqtresptinsttresp_urltprototsafeurltversiont
ntversion_info((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyt_callstreamHs�
































0






















!

 
	












	%


2






cKs2|j|
|�}z|j
�SWd|j�
XdS(
N(RRfR%(RR=Ritfp((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyR+�s


c
Ks�|jd
�}y|j
d�}Wntk
r>


dg
}n
Xx'|D]}|tjkrF|}PqFqFWtj|d|�}tj|j	|d�}i
dd6}	z�ye|j
|
d|d|	|�}
|
j
d	d
�}t|�dkr
tj
td�|
��n|SWnntjk
r{

}
|jd
tjtjfkrb
tjtd�|jd
��ntj|jd
��n
XWd|j�
tj|�
XdS(NtunbundleR?R6trbsapplication/mercurial-0.1sContent-TypeR7R9s

i
isunexpected response:ispush failed: %s(RJR,RatchangegrouptbundletypestwritebundleRthttpconnectionthttpsendfileRR+RGR0t
ResponseErrorR
tsocketRiterrnot
ECONNRESETtEPIPERRR%tostunlink(
RR=tcgRittypest
xttypettempnameR�R9t
rtvalsterr((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyt	_callpush�s2





















#


c
Cs
|
�dS(
N((Rt	exception((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyt_abort�s
cCstj
t|
��S(
N(RtchunkbufferR(Rtstream((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyt_decompress�s
(
t__name__t
__module__R!R(RR-R3R4RR+R�R�R�(((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyRs
					
		b		$	t	httpspeerc
BseZ
d�ZRS(
cCs8tj
s!tjtd
���ntj||
|�
dS(Ns1Python support for SSL and HTTPS is not installed(Rt	has_httpsRRR
RR!(RRR((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyR!�s
	
(R�R�R!(((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyR��s
cCs�|rtj
td
���nys|
jd�rBt||
�}nt||
�}y|j�
Wn*tjk
r�


|j	t
t
fg
�
n
X|SWnatjk
r�
y.tj|d|
|�}|j
d�
|SWq�jk
r�
|�q�
XdS(Ns!cannot create new http repositoryshttps:sstatic-s(falling back to static-http)
(RRR
RdR�RR-R0R1tbetweenRtstatichttprepotinstancetnote(RRtcreateRxt
httpexceptionR�((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyR��s$















(tnodeRti18nR
R�R�R0R�RRt	wireprotoR�RLRSRRR�R�RtwirepeerRR�R�(((s6/sys/lib/python2.7/site-packages/mercurial/httppeer.pyt<module>	s

T
<
	�