�
�c@s
dd
kl
Z
lZlZ
ddklZ
ddkZddkZddkZddk	Z	ddk
Z
ddkZddkZddk
Z
ddkZddkZddkZddkZddkZddkZd�Zdeif
d��YZdef
d��YZd	�ZdS(
i�(tbinthextnullid(
t
_Nc
csuti
�}
y,x%ti|�D]}|
i|�V
qWWn+tij
o



tdt	d
���n
X|
i
�V
dS(Nsconnection ended unexpectedly(tzlibt
decompressobjtutilt
filechunkitert
decompressthttplibt
HTTPExceptiontIOErrortNoneRtflush(t
ftzdtchunk((s%/sys/lib/python/mercurial/httprepo.pyt
zgenerators






thttprepositorycBs�eZ
d�Zd
�Zd�Zd�Zee�Zd�Zd�Z	d�Z
d�Zd�Zd	�Z
d
�Zd�Zd�Zd
�Zd�Zd�ZRS(c	Cs�||_d|_d|_ti|�\}}}}}|p
|o$
titd
�|p
|��n

t	i
|�\|_}|
|_|ii
td�|i�
t	i|
|�|_dS(Nsunsupported URL component: "%s"s	using %s
(tpathRtcapsthandlerturlparseturlsplitRtAbortRturltgetauthinfot_urltuitdebugtopenert	urlopener(	tselfRRtschemetnetlocturlpathtquerytfragtauthinfo((s%/sys/lib/python/mercurial/httprepo.pyt__init__s
	
	
	



	
c
CsCx<|ii
D].}
|
i�
t|
d
�o
|
i�
q

q
WdS(Nt	close_all(RthandlerstclosethasattrR((R t
h((s%/sys/lib/python/mercurial/httprepo.pyt__del__*s






c


Cs|iS(
N(
R(
R ((s%/sys/lib/python/mercurial/httprepo.pyR0s
c

Cs�|idjo{
y"t|id
�i��|_Wn"tij
o



t�|_n
X|iit	d�di
|ip
dg
��
n

|iS(Ntcapabilitiesscapabilities: %s
t
 tnone(RRtsettdo_readtsplitterrort	RepoErrorRRRtjoin(
R ((s%/sys/lib/python/mercurial/httprepo.pytget_caps5s


"



"
c

Csti
td
���dS(Ns!operation not supported over http(RRR(
R ((s%/sys/lib/python/mercurial/httprepo.pytlockAs
cKsx|id
d�}|idh�}|iitd�|
�
h|
d<}|i|�
dti|�}d|i|f}yP|o$
|iitd�t	|��
n

|i
iti
|||��}Wn�tij
o5

}	
|	idjo
titd	���n

�nv
tij
o?

}	
|iitd
�|
�
|ii�
td|	��n)
tj
o



titd���n
X|i�}
|
i|�o
|
t	|� }
n

|i|
jo'
|iitd�|
�
|
|_n

y|id
�}Wn tj
o



|id
}n
Xti|i�}|id�p
|id�p

|id�p@
|iitd�ti|��
t i!td�|��n

|id�o�
yP|i"dd�d}
t#g}|
i"d�D]}|t$|�q��}Wn2t%j
o&



t i!td�||f��n
X|djo#
t i!td�||
f��qt
n

|S(Ntdatatheadersssending %s command
tcmds?%ss%s%sssending %s bytes
i�sauthorization faileds$http error while sending %s command
s,http error, possibly caused by proxy settingsreal URL is %s
scontent-typesapplication/mercurial-s
text/plainsapplication/hg-changegroupsrequested URL: '%s'
s+'%s' does not appear to be an hg repositoryt
-i
t
.s+'%s' sent a broken Content-Type header (%s)is'%s' uses newer protocol %s(ii
(&tpopRRRRtupdateturllibt	urlencodeRtlenRtopenturllib2tRequestt	HTTPErrortcodeRRR	R
t	tracebackRt
IndexErrortgeturltendswithtstatust	getheadertAttributeErrorR:Rthidepasswordt
startswithR4R5R3ttupletintt
ValueError(R R;targsR9R:t
qtqstcutresptinsttresp_urltprototsafeurltversiont_[1]t
ntversion_info((s%/sys/lib/python/mercurial/httprepo.pytdo_cmdDsb










$
%






















#




:






cKs2|i|
|�}z|i
�SWd|i�
XdS(
N(RatreadR*(R R;RTtfp((s%/sys/lib/python/mercurial/httprepo.pyR2}s


cCs{|id
t
d��
|id
d|
�
i�}|d idd�\}}t|�o
t|�Sn

ti|��dS(Ntlookupslook up remote revisiontkeyi�R/i
(	t
requirecapRRaRbR3RRRR4R5(R Ret
dtsuccessR9((s%/sys/lib/python/mercurial/httprepo.pyRd�s






c
CsS|id
�}
yt
t|
d id��SWn


titd�|
��n
XdS(Ntheadsi�R/sunexpected response:(R2tmapRR3R4t
ResponseErrorR(R Rg((s%/sys/lib/python/mercurial/httprepo.pyRi�s





c

Cs�|id
�}
y|h}xk|
i
�D]]}|id�}ti|d�}g}|dD]}|t|�q\~}|||<q%W|SWn


titd�|
��n
XdS(Nt	branchmapR/ii
sunexpected response:(	R2t
splitlinesR3R@tunquoteRR4RkR(R RgRlt
branchparttbranchheadst
branchnameR^t
x((s%/sys/lib/python/mercurial/httprepo.pyRl�s







+



cCs�d
it
t|
��}|idd|�
}yGg}|i�D]%}|tt
t|id
���qA~}|SWn


ti	t
d�|��n
XdS(NR/tbranchestnodessunexpected response:(R6RjR
R2RmRQRR3R4RkR(R RtR_RgR^t
btbr((s%/sys/lib/python/mercurial/httprepo.pyRs�s



?


cCs
d
}g}x�dt
|
�|�D]�}dig}|
|||!D]}|ditt|��qG~�}|idd|�
}yO|g}	|i�D]-}
|	|
o
tt|
id��p
gq�~	7}Wq%


t	i
td�|��q%Xq%W|S(NiiR/R<tbetweentpairssunexpected response:(txrangeRBR6RjR
R2RmRR3R4RkR(R Rxtbatcht
rt
iR^t
pR_Rgt_[2]t
l((s%/sys/lib/python/mercurial/httprepo.pyRw�s



G


O

 
cCs@d
it
t|
��}|idd|�
}tit|��S(NR/tchangegrouptroots(R6RjR
RaRtchunkbufferR(R RttkindR_R((s%/sys/lib/python/mercurial/httprepo.pyR��s


c

Cs�|id
t
d��
dig}|
D]}|t|�q'~�}dig}|D]}|t|�qW~�}|id
d|d|�}	tit|	��S(Ntchangegroupsubsetslook up remote changesR/tbasesRi(RfRR6R
RaRR�R(
R R�RitsourceR^R_tbaselstR~theadlstR((s%/sys/lib/python/mercurial/httprepo.pyR��s


0
0

cCs�d
}|id�}y|i
d�}Wntj
o



d
g
}n
X|o0
x-|D]!}|tijo
|}PqU
qUWn

ti|
d|�}ti|d�}z
y�|i	dd|dhdd<d	d
i
tt|���}	|	i
dd�\}
}yt
|
�}Wn-tj
o!

}

titd
�|	��n
X|ii|�
|SWnitij
oZ

}

|
dtitifjo!
titd�|
d��n

ti|
d��n
XWd|i�
ti|�
XdS(Nttunbundlet
,trbR9R:sapplication/octet-streamsContent-TypeRiR/s

i
s"push failed (unexpected response):ispush failed: %s(tcapableR3RNR�tbundletypestwritebundleRRthttpsendfileR2R6RjR
RRRSR4RkRRtwritetsocketterrnot
ECONNRESETtEPIPERRR*tostunlink(R tcgRiR�ttypettypesRrttempnameRcRXt	resp_codetoutputtretterr((s%/sys/lib/python/mercurial/httprepo.pyR��sD



























!


c

Cs
|id
�S(Nt
stream_out(
Ra(
R ((s%/sys/lib/python/mercurial/httprepo.pyR��s
(t__name__t
__module__R'R-RR7tpropertyR.R8RaR2RdRiRlRsRwR�R�R�R�(((s%/sys/lib/python/mercurial/httprepo.pyRs"
				
		9				
						*thttpsrepositoryc
BseZ
d�ZRS(
cCs:ti
p
titd
���n

ti||
|�
dS(Ns1Python support for SSL and HTTPS is not installed(Rt	has_httpsRRRRR'(R RR((s%/sys/lib/python/mercurial/httprepo.pyR'�s


(R�R�R'(((s%/sys/lib/python/mercurial/httprepo.pyR��s
cCs�|o
ti
td
���n

yP|
id�o
t||
�}n
t||
�}|ittfg
�
|SWn:ti	j
o+



|i
d�
ti|d|
|�Sn
XdS(Ns!cannot create new http repositoryshttps:s(falling back to static-http)
sstatic-(
RRRRPR�RRwRR4R5tnotetstatichttprepotinstance(RRtcreateRY((s%/sys/lib/python/mercurial/httprepo.pyR��s










(tnodeRR
Rti18nRtrepoR�R�R4RRR�R@RDRRR	R�R�Rt
repositoryRR�R�(((s%/sys/lib/python/mercurial/httprepo.pys<module>	s

H
H
		�