ó —¤Ø[c@s,ddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddlm Z m Z m Z dejfd„ƒYZdejfd„ƒYZdefd „ƒYZd efd „ƒYZd efd „ƒYZdefd„ƒYZd„Zd„ZdS(iÿÿÿÿN(tpython_version(t _CS_REQ_SENTt_CS_IDLEtResponseNotReadyt HTTPResponsecBseZd„ZRS(cCsMt|jtjƒs-tj|jƒ|_n|jj|||||ƒdS(N(t isinstancetfpt nonblockingtNonBlockingFilet 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.pyRstHTTPConnectioncBsDeZeZdejd„Zd„Zd„Z d„Z d„Z RS(cCs‡tƒdkr.tjj|||d|ƒntjj|||ƒ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 R R RR((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR -s     cCs ||_dS(N(R(R t user_agent((s3/usr/lib/python2.7/site-packages/rhn/connections.pytset_user_agent5scCsî|jr$|jjƒr$d|_n|jtks<|jrHtƒ‚n|jdkrr|j|j|jƒ}n|j|jƒ}|j r¸|j |j |j |j |j|j ƒn|jƒt|_|jrá|jƒn ||_|S(s!Get the response from the server.iN(t_HTTPConnection__responsetisclosedRt_HTTPConnection__stateRRt debugleveltresponse_classtsockRR RRRRtbeginRt will_closetclose(R tresponse((s3/usr/lib/python2.7/site-packages/rhn/connections.pyt getresponse:s         cCs'tjj|ƒ|jj|jƒdS(N(RRtconnectR&t settimeoutR(R ((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR,ksN( RRRR%RtSSLtDEFAULT_TIMEOUTRR R R+R,(((s3/usr/lib/python2.7/site-packages/rhn/connections.pyRs    1tHTTPProxyConnectioncBs>eZdddejd„Zd„Zdd„Zd„ZRS(cCsntj||d|ƒ|j|j|_|_|j||ƒ|j|j|_|_||_ ||_ dS(NR( RRRRt_HTTPProxyConnection__proxyt _HTTPProxyConnection__proxy_portt _set_hostportt_hostt_portt_HTTPProxyConnection__usernamet_HTTPProxyConnection__password(R tproxyRRtusernametpasswordR((s3/usr/lib/python2.7/site-packages/rhn/connections.pyRqs  cCs=|j|j|jƒtj|ƒ|j|j|jƒdS(N(R3R1R2RR,R4R5(R ((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR,s icCsl|j}|j|jkr5|dt|jƒ}nd||f}tj|||d|ƒ|jƒdS(Nt:s http://%s%st skip_host(R4R5t default_porttstrRt putrequestt_add_proxy_headers(R tmethodturlR<thostnametnewurl((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR?†s  cCsV|js dSd|j|jf}tj|ƒjddƒ}|jdd|ƒdS(Ns%s:%ss tsProxy-AuthorizationsBasic %s(R6R7tbase64t encodestringtreplacet putheader(R tuserpasst enc_userpass((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR@‘s  N( RRRR.R/RR,R?R@(((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR0ps    tHTTPSConnectioncBs8eZeZejjZddej d„Z d„Z RS(cCs2tj|||d|ƒ|p"g}||_dS(NR(RRt trusted_certs(R RRRMR((s3/usr/lib/python2.7/site-packages/rhn/connections.pyRs c Cs&tj|j|jtjtjƒ}x¸|D]°}|\}}}}}ytj|||ƒ}Wntjk r€} d}q+nXy-|j|j|jfƒ|j |j ƒWn)tjk rÙ} |j ƒd}q+nXPq+W|dkrýtjdƒ‚nt j ||jƒ|_|jjƒdS(s'Connect to a host on a given (SSL) ports0Unable to connect to the host and port specifiedN(tsockett getaddrinfoRRt AF_UNSPECt SOCK_STREAMterrorRR,R-RR)R.t SSLSocketRMR&tinit_ssl( R tresultstrtaftsocktypetprotot canonnametsaR&tmsgte((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR,£s*   N( RRRR%RRLR=RR.R/RR,(((s3/usr/lib/python2.7/site-packages/rhn/connections.pyRL™s  tHTTPSProxyResponsecBseZd„ZRS(cCstj|ƒ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.pyR^¿stHTTPSProxyConnectioncBsJeZejZddddejd„Zd„Zdd„Z d„Z RS(c Cs;tj||||||d|ƒ|p+g}||_dS(NR(R0RRM(R R8RRR9R:RMR((s3/usr/lib/python2.7/site-packages/rhn/connections.pyRÇs  cCsê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È(R0R,R4R5RR?R@t endheadersR%R^R+R)tstatust xmlrpclibt ProtocolErrortreasonR\R.RSR&RMRT(R RR%R*((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR,Îs          icCstj|||d|ƒS(NR<(RR?(R RARBR<((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR?êscCs$tj|ƒ|jd|jƒdS(Ns User-Agent(R0R@RIR(R ((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR@ís N( RRRLR=RR.R/RR,R?R@(((s3/usr/lib/python2.7/site-packages/rhn/connections.pyR_Äs     cCs!|dkrdS|jdƒSdS(sE Convert Internationalized domain name from Pune encoding to Unicode tidnaN(Rtdecode(RC((s3/usr/lib/python2.7/site-packages/rhn/connections.pytidn_pune_to_unicodeòs cCsB|dkrdSt|tƒs1t|dƒ}n|jdƒSdS(sU Convert domain name to Pune encoding. Hostname can be instance of string or Unicode sutf-8RfN(RRtunicodetencode(RC((s3/usr/lib/python2.7/site-packages/rhn/connections.pytidn_ascii_to_puneùs  (tsysRFR.RRRctencodings.idnat encodingsRNtplatformRRRRRRR0RLR^R_RhRk(((s3/usr/lib/python2.7/site-packages/rhn/connections.pyt s"        S)&.