�
�+Xc@s�
dd
lZdd
l
Z
dd
lZdd
lZdd
lZddlmZ
ddlm	Z	
ddlm
Z

ddlmZ
y8dd
lZddlm
Z
mZmZ
dd
lZWnKek
r




dd
ljZddlm
Z
mZmZ
dd
ljZn
Xdejf
d��YZd	ejf
d
��YZdef
d��YZd
ef
d��YZdef
d��YZdef
d��YZd�Zd�Zd
S(i����N(
tpython_version(
tSSL(
tnonblocking(
ti18n(t_CS_REQ_SENTt_CS_IDLEtResponseNotReadytHTTPResponsec
BseZ
d�ZRS(
cCsMt|j
tj�s-tj|j
�
|_
n|j
j|
||||�
dS(
N(t
isinstancetfpRtNonBlockingFiletset_callback(tselftrstwstext	user_datatcallback((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR!s


(t__name__t
__module__R(((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR s
tHTTPConnectioncBsDeZ
eZdejd�Zd
�Zd�Z	d�Z
d�ZRS(cCs�t�d
kr.t
jj||
|d|�

nt
jj||
|�
g|_g|_g|_d|_d|_	d|_
||_dS(Ns2.6.1ttimeouts#rhn.connections $Revision$ (python)(RthttplibRt__init__t_cb_rst_cb_wst_cb_extNonet
_cb_user_datat_cb_callbackt_user_agentR(RthosttportR((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR)s


	
	
	
	
	
	
cCs1|
|_||_
||_||_||_dS(
N(RRRRR(RR
RRRR((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR6s
	
	
	
	
cCs
|
|_dS(
N(
R(Rt
user_agent((s3/usr/lib/python2.7/site-packages/rhn/connections.pytset_user_agent>s
c
Cs
|jr$|jj
�r$d|_n|jtks<|jrHt��
n|jd
krr|j|j|j�}
n|j|j�
}
|j	r�|
j
|j|j|j
|j|j	�
n|
j�
|
jtjks�t�
t|_|
jr�|j�
n	|
|_|
S(s!Get the response from the server.iN(t_HTTPConnection__responsetisclosedRt_HTTPConnection__stateRRt
debugleveltresponse_classtsockRRRRRRtbegint
will_closeRt_UNKNOWNtAssertionErrorRtclose(Rtresponse((s3/usr/lib/python2.7/site-packages/rhn/connections.pytgetresponseCs"


	




		
	c

Cs'tj
j|�

|jj|j�

dS(
N(RRtconnectR(t
settimeoutR(
R((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR0ts

N(RRRR'RR
tDEFAULT_TIMEOUTRRR"R/R0(((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR&s

			1tHTTPProxyConnectioncBs>eZ
dddejd�Zd
�Zdd�
Zd�ZRS(cCsntj
||
d
|�

|j|j|_|_|j||�
|j|j|_|_||_	||_
dS(NR(RRRR t_HTTPProxyConnection__proxyt _HTTPProxyConnection__proxy_portt
_set_hostportt_hostt_portt_HTTPProxyConnection__usernamet_HTTPProxyConnection__password(RtproxyRR tusernametpasswordR((s3/usr/lib/python2.7/site-packages/rhn/connections.pyRzs	
c

Cs=|j|j
|j�
tj|�

|j|j|j�
dS(
N(R6R4R5RR0R7R8(
R((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR0�s

icCsl|j}|j
|jkr5|d
t|j
�
}nd||f}tj||
|d|�

|j�
dS(Nt
:shttp://%s%st	skip_host(R7R8tdefault_porttstrRt
putrequestt_add_proxy_headers(RtmethodturlR?thostnametnewurl((s3/usr/lib/python2.7/site-packages/rhn/connections.pyRB�s	


c
CsV|js
dSd
|j|j
f}
tj|
�
jdd�}|jdd|�
dS(Ns%s:%ss

tsProxy-AuthorizationsBasic %s(R9R:tbase64tencodestringtreplacet	putheader(Rtuserpasstenc_userpass((s3/usr/lib/python2.7/site-packages/rhn/connections.pyRC�s

	


N(	RRRR
R2RR0RBRC(((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR3ys

	

	tHTTPSConnectioncBs8eZ
eZejjZddej	d�Z
d
�ZRS(cCs2tj
||
|d
|�

|p"g}||_dS(NR(RRt
trusted_certs(RRR RPR((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR�s

c

Cs#
tj
|j|jtjtj�}
x�|
D]�}|\}}}}}yBtj|||�}|j|j|jf�

|j|j�

WnLtj	k
r�


t
j�d
}	|	jtj
kr+|j�
d}q+q+n
XPq+W|dkr�tj	d�
�
ntj||j�|_|jj�
dS(s'Connect to a host on a given (SSL) porti
s0Unable to connect to the host and port specifiedN(tsockettgetaddrinfoRR t	AF_UNSPECtSOCK_STREAMR0R1Rterrortsystexc_infoterrnotEINTRR-RR
t	SSLSocketRPR(tinit_ssl(
Rtresultst
rtaftsocktypetprotot	canonnametsaR(t
e((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR0�s&












	



N(RRRR'RROR@RR
R2RR0(((s3/usr/lib/python2.7/site-packages/rhn/connections.pyRO�s



tHTTPSProxyResponsec
BseZ
d�ZRS(
c

Cstj
|�

d
|_dS(Ni(RR)R*(
R((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR)�s


(RRR)(((s3/usr/lib/python2.7/site-packages/rhn/connections.pyRd�s
tHTTPSProxyConnectioncBsJeZ
ejZddddejd�Zd
�Zdd�
Z	d�Z
RS(c	Cs;tj
||
||||d
|�

|p+g}||_dS(NR(R3RRP(RR;RR R<R=RPR((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR�s



c
Cs�tj
|�

d
|j|jf}
tj|d|
�
|j�
tj|�

|j}t	|_tj
|�
}||_|j�
|jdkr�|j�
t
j|
|j|j|j��
ntj|j|j�|_|jj�
dS(Ns%s:%stCONNECTi�(R3R0R7R8RRBRCt
endheadersR'RdR/R-tstatust	xmlrpclibt
ProtocolErrortreasontmsgR
RZR(RPR[(RRR'R.((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR0�s 



		
	



	


icCstj
||
|d
|�
S(NR?(RRB(RRDRER?((s3/usr/lib/python2.7/site-packages/rhn/connections.pyRB�s
c

Cs$tj
|�

|jd
|j�
dS(Ns
User-Agent(R3RCRLR(
R((s3/usr/lib/python2.7/site-packages/rhn/connections.pyRC�s

N(RRROR@RR
R2RR0RBRC(((s3/usr/lib/python2.7/site-packages/rhn/connections.pyRe�s
		
	c

Cs0|dkrdSt
j|�
}|jd
�
SdS(sJ Convert Internationalized domain name from Punycode (RFC3492) to Unicode tidnaN(RRtbstrtdecode(
RF((s3/usr/lib/python2.7/site-packages/rhn/connections.pytidn_puny_to_unicode�s

c

Cs0|dkrdSt
j|�
}|jd
�
SdS(sZ Convert domain name to Punycode (RFC3492). Hostname can be instance of string or Unicode RmN(RRtustrtencode(
RF((s3/usr/lib/python2.7/site-packages/rhn/connections.pytidn_ascii_to_puny
s

(RVRItencodings.idnat	encodingsRQRXtplatformRtrhnR
RRRRRRRitImportErrorthttp.clienttclientt
xmlrpc.clientRRR3RORdReRpRs(((s3/usr/lib/python2.7/site-packages/rhn/connections.pyt<module>	s0











S)#.