�t�c@s�dd
lZdd
l
Z
dd
lZdd
lZdd
lZddlmZ
ddlmZ
ddlmZ
ddl	m
Z

def
d��YZd�Z
d	ejf
d
��YZdejf
d��YZead
Zdejejfd��YZd
S(i�N(
t
httpclient(
tsslutil(
tutil(
t
_thttpsendfilec
Bs eZ
dZd
�Zd�ZRS(s�This is a wrapper around the objects returned by python's "open".

    Its purpose is to send file-like objects via HTTP.
    It do however not define a __len__ attribute because the length
    might be more than Py_ssize_t can handle.
    cOs�|
|_t
||�|_|jj|_|jj|_|jj|_tj|jj��j	|_
d
|_|j
dd|_dS(Niii(
tuitopent_datatseektclosetwritetostfstattfilenotst_sizetlengtht_post_total(tselfRtargstkwargs((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyt__init__s	





	
c
Os�y|jj
|
|�}Wn*tk
rE


|jjtd
�d�
n
X|jt|�7_|jjtd
�|jddtd�d|j	�
|S(Ntsendingitunittkbttotal(
RtreadtEOFErrorRtprogressRtNoneRtlenR(RRRtret((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyR+s







(t__name__t
__module__t__doc__RR(((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyRs	
c
CsIt�}x�|j
d
�D]�\}}d|krN|jtd�|�
qn|jdd�\}}|j|t��}|dkr�tj|�}n|||<qWd|
kr�|
jdd�\}	}
n
d	|
}	}
d}d
}d}
xU
|j
�D]G
\}}|r*
||jd|�kr*
q�|jd�}|sE
q�|jdd�}t|�dkr�|d
g
|d}}n|jd�p�d
j�}|dks�|
j
|�r�|�|ks�|�|kr�r�|kr�|kr�|�}||f}
|jd�}|rA|rA||d<qAq�W|
S(Ntautht
.s!ignoring invalid [auth] key '%s'
i
tusernametcerttkeys://thttpitprefixtschemesthttpst
*(susernameR&skey(tdicttconfigitemstwarnRtrsplitt
setdefaultRt
expandpathtsplitRt	iteritemstgetRt
startswith(RturitusertconfigR'tvaltgrouptsettingtgdicttschemethostpathtbestusertbestlentbestauthR#R)t
pR*((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pytreadauthforuri;sH	























$








tHTTPResponsec
BseZ
d�ZRS(
c


CsdS(
N((
R((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyR	ms
(R R!R	(((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyREls
tHTTPConnectioncBseZ
eZd
id�ZRS(cCsEt|t
�r|jd
�
ntjj||
|d|d|�
dS(Nitbodytheaders(t
isinstanceRRRRFtrequest(RtmethodR7RGRH((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyRJrs



N(R R!REtresponse_classRRJ(((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyRFps

s-%(levelname)s:%(name)s:%(lineno)d:%(message)sthttp2handlercBsAeZ
d�Zd
�Zd�Zd�Zd�Zdd�ZRS(cCs�tj
j|�
|
|_||_i|_|
jd
ddd�
}|r�tr�t	at
jd�}|jt
t
|j���
t
j�}|jt
jt��
|j|�
ndS(NRthttp2debugleveltdefaultsmercurial.httpclient(turllib2tAbstractHTTPHandlerRRtpwmgrt_connectionsR9Rt_configuredloggingtTruetloggingt	getLoggertsetLeveltgetattrtuppert
StreamHandlertsetFormattert	FormattertLOGFMTt
addHandler(RRRRtlogleveltloggerthandler((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyRs
	
	
	








c
CsBx2|jj
�D]!}
x|
D]}|j�
qWqWi|_d
S(s=Close and remove all connection objects being kept for reuse.N(RStvaluesR	(Rt	openconnstconn((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyt	close_all�s



cCs�t|d
d
�}|j�}|r3|}|}nM|j�rz|j�}|j�jdd�djdd�d}nd
}|r�d|kr�|jdd�\}}nd}||f}nd
}|s�jd��n|||f}	|j	j
|	g�}
g|
D]}|j�s
|^q
}|r<
|d}
nu|
rY
|jj
d	|�
nd
}|jtjk	r}
|j}n|
|d
|d|�}
|j	j|	g�j|
�
t|j�}|j|j�
td�|j�D��}y�|j�}d|kr0|jdd�djdd�d}n|ddkrMd|}n|
j|j�||j|�
|
j�}Wn%tjk
r�
}
tj|��n
X|j|_tj ||j|j!��}|j"|_#|j$|_%|S(s�Return an addinfourl object for the request, using http_class.

        http_class must implement the HTTPConnection API from httplib.
        The addinfourl return value is a file-like object.  It also
        has methods and attributes including:
            - info(): return a mimetools.Message object for the headers
            - geturl(): return the original request URL
            - code: HTTP status code
        t_tunnel_hosts://i
t
/it
:i8s
no host givens.all connections for %s busy, making a new one
ttimeouttproxy_hostportc
ss'|]\}
}|
j�|fV
qdS(
N(
ttitle(t.0tnameR:((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pys	<genexpr>�sN(&RYRtget_hostt	has_proxytget_selectorR3R0RPtURLErrorRSR5tbusyRtdebugRjtsockett_GLOBAL_DEFAULT_TIMEOUTR1tappendR-RHtupdatetunredirected_hdrstitemsRJt
get_methodtdatatgetresponseterrorRtrecvturllibt
addinfourltget_full_urltstatustcodetreasontmsg(Rt
http_classtreqtuse_sslttunhostthostt	proxyhostt	proxyporttproxytconnkeytallconnst
ctconnst
hRjRHtpatht
rterrtresp((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pytdo_open�sb



	


/




%
















)









cCs>|
j�j
d
�r"|j|
�Sd�}|j||
t�S(NR+c_s#t|
�}t
|d
<t||�S(NR�(R-tFalseRF(RRtk2((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pytmakehttpcon�s



(R�R6t
https_openR�R�(RR�R�((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyt	http_open�s



	cCs�|
j�}|j
j|�\}}t|j||�}|rk|\}}||_|jjd
|�
n	d|_|j|j	|
t
�S(Ns#using auth.%s.* for authentication
(R�RRtfind_stored_passwordRDRR#RtRR�t_makesslconnectionRU(RR�turlR8tpasswordtresR;R#((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyR��s




	
	
i�c
OsZ
d}d}|r$|j
d
�}n|r<|j
d
�}n|jr�d|jkr�d|jkr�|jd}|jd}nd|
kr�d|
ks�d|
kr�
jdd�\}
}t|�}d|
kr�
dd!}
q�|r�|d	<n|r

||d
<n|jtj|j|
��
t	|
|dt
dtj|j|
�|�}|S(
NiR'R&Rit
[s]:i
i�tkeyfiletcertfileR�t
ssl_validator(RtpopR#R0tintRxR
t	sslkwargsRRFRUt	validator(RR�tportRRR�R�tcon((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyR�
s.




'


$










	
(R R!RRfR�R�R�R�(((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyRM~s
			S			(RVRuR�RPRt	mercurialRR
Rtmercurial.i18nRtobjectRRDRERFR�RTR^tHTTPHandlertHTTPSHandlerRM(((s</sys/lib/python2.7/site-packages/mercurial/httpconnection.pyt<module>
s






%	1