/
lib64
/
python2.7
/
site-packages
/
mercurial
/
httpclient
/
Upload File
HOME
� Hq�Qc @ s� d Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z e j e � Z d d g Z d Z d Z d d >Z d d >Z d Z d Z d Z d Z d Z d Z d Z e d Z d Z e Z d e f d � � YZ d e f d � � YZ d e j f d � � YZ! d e j f d � � YZ" d e j f d � � YZ# d e j f d � � YZ$ e j% Z% d S( sX Improved HTTP/1.1 client library This library contains an HTTPConnection which is similar to the one in httplib, but has several additional features: * supports keepalives natively * uses select() to block for incoming data * notices when the server responds early to a request * implements ssl inline instead of in a different class i����Nt HTTPConnectiont HTTPResponses HTTP/1.0s HTTP/1.1i i i s accept-encodingt connections content-lengths transfer-encodingt chunkedt closes i c B s_ e Z d Z d � Z e d � � Z d � Z d � Z d � Z d d � Z d � Z d � Z RS( s� Response from an HTTP server. The response will continue to load as available. If you need the complete response before continuing, check the .complete() method. c C s� | | _ | | _ d | _ d | _ d | _ t | _ d | _ d | _ t | _ d | _ d | _ d | _ d | _ t | _ | | _ d S( Nt i ( t sockt methodt raw_responset _headers_lent Nonet headerst Falset will_closet status_linet statust continuedt http_versiont reasont _readert _read_locationt EOLt _eolt _timeout( t selfR t timeoutR ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyt __init__U s c C s | j d S( Ni ( R ( R ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyt _end_headersh s c C s | j r | j j � Sd S( s Returns true if this response is completely loaded. Note that if this is a connection where complete means the socket is closed, this will nearly always return False, even in cases where all the data has actually been loaded. N( R t done( R ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyt completel s c C s# | j d k r | j j � n d S( N( R R t _close( R ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyR v s c C sg g } xQ t rY | j j d | � | r< | d d d k sH | j � rL Pn | j � q Wd j | � S( s� Read a single line from the response body. This may block until either a line ending is found or the response is complete. s i����R ( t TrueR t readtoR t _selectt join( R t blocks( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyt readlinez s &c C s� x4 | j � r6 | s) | | j j k r6 | j � q W| sL | j j } n | j j | � } | j � r� | j r� | j j � n | S( N( R R t available_dataR! t readR R R ( R t lengtht r( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyR& � s c C s t j | j g g g | j � \ } } } | sa | j � sa t j d | j � t d � � qa n y | j j t � } Wn@ t j k r� } | j d t j k r� � n t j d � t SXt j d t | � � | s� | j r� | j j � n t S| j | � t Sd S( Ns timed out with timeout of %ss timeout reading datai s2 SSL_ERROR_WANT_READ in _select, should retry laters$ response read %d data during _select( t selectR R R t loggert infot HTTPTimeoutExceptiont recvt INCOMING_BUFFER_SIZEt sockett sslerrort argst SSL_ERROR_WANT_READt debugR t lenR R R t _load_response( R R( t _t datat e( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyR! � s& * c C se | j | 7_ | j | j k r� xb d D]W } | | j k r( | j j | � t | j � d k r( t j d | � | | _ Pq( q( Wn | j | j k s� | j r� d S| j j | j d � \ } } | j d d � \ } } | j d � r| | _ t | _ t j d | � d S| j j | j d � \ } } | ` | j | k rd| j | j d � \ | _ } n | | _ d } | j j d d � \ | _ | _ | _ t | j � | _ | j t k r�| j | j d � } n t j t j | � � } d } t | k rt | t � } n | j t k r+t | _ n( t | k rS| t j � t k | _ n t | k r�| t j � t k r�t! j" | j � | _# t j d � n� | j$ d k s�| j$ d k r�| d k r�d } n | d k r�t j d | � t! j% | � | _# n% t! j& � | _# t j d � t | _ | r<| j# j' | � n t j d � | | _ | j# j' | _( d S( Ns s i s- bogus line endings detected, using %r for EOLt t 100s! continue seen, setting body to %rR i s s using a chunked readert HEADt CONNECTi s, using a content-length reader with length %ds using a close-is-end readers headers complete( s s () R R t indexR4 R* R+ R R t splitt startswithR R R3 R R R R t intR t replacet rfc822t Messaget cStringIOt StringIOR t HDR_CONTENT_LENGTHt HTTP_VER_1_0R t HDR_CONNECTION_CTRLt lowert CONNECTION_CLOSEt HDR_XFER_ENCODINGt XFER_ENCODING_CHUNKEDt _readerst ChunkedReaderR R t ContentLengthReadert CloseIsEndReadert _loadR5 ( R R7 t bad_eolt hdrst bodyt http_verR R t content_len( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyR5 � sp ! ' N( t __name__t __module__t __doc__R t propertyR R R R$ R R& R! R5 ( ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyR O s c B st e Z d Z e Z e Z d d d e e d d � Z d � Z d � Z d � Z d � Z d i e d � Z d � Z RS( s� Connection to a single http server. Supports 100-continue and keepalives natively. Uses select() for non-blocking socket operations. c K s� | d k r! | j d � d k s- d | k rp | j d d � \ } } t | � } d | k rp | d d !} qp n | d k r� | d k r� t } d } n< | d k r� | d k } n! | d k r� | r� d p� d } n | | _ | r� t j r� t d � � n | | _ | | _ | | _ | | _ d | _ d | _ t | _ | d k rYd | _ | _ n | \ | _ | _ | | _ | | _ d S( s Create a new HTTPConnection. Args: host: The host to which we'll connect. port: Optional. The port over which we'll connect. Default 80 for non-ssl, 443 for ssl. use_ssl: Optional. Whether to use ssl. Defaults to False if port is not 443, true if port is 443. ssl_validator: a function(socket) to validate the ssl cert timeout: Optional. Connection timeout, default is TIMEOUT_DEFAULT. continue_timeout: Optional. Timeout for waiting on an expected "100 Continue" response. Default is TIMEOUT_ASSUME_CONTINUE. proxy_hostport: Optional. Tuple of (host, port) to use as an http proxy for the connection. Default is to not use a proxy. t :i s ]:t [i����iP i� s, ssl requested but unavailable on this PythonN( R t countt rsplitR@ R t portt socketutilt have_sslt Exceptiont sslt ssl_optst _ssl_validatort hostR t _current_responset _current_response_takent _proxy_hostt _proxy_portR t continue_timeout( R Rf R_ t use_sslt ssl_validatorR Rk t proxy_hostportRd ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyR s6 - c C s� | j r d S| j d k rdt j d | j | j � t j | j | j f � } | j r| j d d | j | j f i t � } | j | � | j d � | j | | j d � } t d � } xR | j � sy( | j � s� | j � s� | � q� n Wq� t k r| � q� Xq� W| j d k rEt d | j | j � f � � n t j d | j | j � qn t j | j | j f � } | j r�| j d � t j d | j � t j | | j � } | j r�| j | � q�n | j d � | | _ d S( s3 Connect to the host and port specified in __init__.Ns Connecting to http proxy %s:%sR< s %s:%di s1 Timed out waiting for CONNECT response from proxyi� s Proxy connection failed: %d %ss/ CONNECT (for SSL) to %s:%s via proxy succeeded.i s' wrapping socket for ssl with options %r( R Ri R R* R+ Rj R` t create_connectionRc t buildheadersRf R_ RG t sendt setblockingt response_classR R, R R! R t HTTPProxyConnectFailedExceptionR& R3 Rd t wrap_socketRe ( R R R7 R( t timeout_exc( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyt _connectG sN c C s= | j r | j d k s' | j d k r3 | j } n> d | j k r[ d | j | j f } n d | j | j f } | j r� | j r� | d d k s� t d � � d | | f } n d | | | t f g } d | f | d <t d f | t <x4 | j � D]& \ } } | j d | | t f � q� W| j t � d j | � S( Ni� iP R[ s [%s]:%ds %s:%di t /s path must start with a /s http://%s%ss %s %s %s%st HostRf t identitys %s: %s%sR ( Rc R_ Rf Ri t AssertionErrorR t HDR_ACCEPT_ENCODINGt itervaluest appendR" ( R R t pathR RU t hdrhostt outgoingt hdrt val( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyRp { s ' c C sF | j d k r d S| j j � d | _ t j d | j | j � d S( s� Close the connection to the server. This is a no-op if the connection is already closed. The connection may automatically close if requested by the server or required by the nature of a response. Ns closed connection to %s on %s( R R R R* R+ Rf R_ ( R ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyR � s c C sa | j } | d k r] | j rY | j r= d | _ d | _ t S| j � rY d | _ t Sn t St S( s� Returns True if this connection object is currently in use. If a response is still pending, this will return True, even if the request has finished sending. In the future, HTTPConnection may transparently juggle multiple connections to the server, in which case this will be useful to detect if any of those connections is ready for use. N( Rg R Rh R R R R R ( R t cr( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyt busy� s c s/ � j � r t j d � � n t � _ t j d | | � j � j � t d � | j � D� � } | j d d � d j � d k r� t } n | r� d | d <n t } | r t | k r t | d t � r� t t | � f | t <q t | d t � rt t f | t <t } q t d � � n � j � � j | | | � j � } d } t } � f d � } xF| sl| r�| o{| j � r�� j } | p�| } t } | r�| r�| o�| j p�| j r�t j d � j � � j } t } t } n | r � j g } n g } t j � j g | g | � \ } } } | | k oO| k oOg k n r| rpt } t j d � qt d � � n | } | r yVy | d j t! � } WnB t" j# k r�} | j$ d t" j% k r�� n t j& d � w`n X| s�t j d � d � _ d � _' | d k r(| j( � n | d k rQ| j � rQt j d � Pq�| r�| d k r�t j d � | d � w`q�t) d � � n t j& d t | � � | d k r�� j* | d � j | � } n | j+ | � w`Wq t" j, k r} | d t- j. k r| r� qq Xn | r`| r`y� t | d t � r�| j/ t0 � } | sYw`n t | � t0 k r�| r�d t1 t1 } q�d } n | r�t2 t | � � d t1 | t1 } q�| } n | d j3 | � } Wn} t" j, k rR} | d t" j4 k r � j5 r q`n) | d t- j6 t- j. f k r3| r3� n | d � � j j3 | � } n Xt j& d | � t } | r|| | } n | | k r�| | } q�| | } q`q`W| d k r�� j* � j � j | � } n | j � } t7 | p�| � } | r t j d � t | _8 n | j8 r"d � _ n | � _' d S( s� Send a request to the server. For increased flexibility, this does not return the response object. Future versions of HTTPConnection that juggle multiple sockets will be able to send (for example) 5 requests all at once, and then let the requests arrive as data is available. Use the `getresponse()` method to retrieve the response. s= Can not send another request before current response is read!s* sending %s request for %s to %s on port %sc s s- | ]# \ } } | j � | | f f Vq d S( N( RI ( t .0t kt v( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pys <genexpr>� s t expectR i s 100-continuet Expects 100-Continuet __len__R& s body has no __len__() nor read()c s( t j d | � � j � � j � d S( Ns reconnecting during %s( R* R+ R Rw ( t where( R ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyt reconnect� s s: waiting up to %s seconds for continue response from serversT no response to continue expectation from server, optimistically sending request bodys timeout sending datai s3 SSL_ERROR_WANT_READ while sending data, retrying...s socket appears closed in reads2 Got an early response, aborting remaining request.sO Connection appeared closed in read on first request loop iteration, will retry.sj Connection appears closed after some request data was written, but the response was missing or incomplete!s read %d bytes in request()t 0i t writes sent %ds@ stopped sending request early, will close the socket to be safe.N( R R ( R� s 100-Continue(9 R� t httplibt CannotSendRequestR Rh R* R+ Rf R_ t dictt iteritemst getRI R RF t getattrR4 RK RL t BadRequestDataRw Rp R R R R R R Rk R R) R, R- R. R/ R0 R1 R2 R3 Rg R t HTTPStateErrorRs R5 t errort errnot EPIPER& t OUTGOING_BUFFER_SIZER t hexRq t SSL_ERROR_WANT_WRITERc t ECONNRESETt boolR ( R R R RT R t expect_continueRS R t outgoing_headerst responset firstR� t select_timeoutt outt blocking_on_continuet wR( t xt was_firstR7 R8 t amtt sent_dataR t data_left( ( R sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyt request� s� " '' % c C s� | j d k r t j � � n | j } x< | j d k re | j � r* | j � r* t j � � q* q* W| j r� d | _ d | _ n! | j � r� d | _ n t | _ | S( N( Rg R R� t ResponseNotReadyR R! R RM t HTTPRemoteClosedErrorR R R Rh ( R R( ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyt getresponsew s N( RW RX RY t HTTP_VER_1_1R R Rs R t TIMEOUT_DEFAULTt TIMEOUT_ASSUME_CONTINUER Rw Rp R R� R R� R� ( ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyR s . 4 �R, c B s e Z d Z RS( s/ A timeout occurred while waiting on the server.( RW RX RY ( ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyR, � s R� c B s e Z d Z RS( s1 Request body object has neither __len__ nor read.( RW RX RY ( ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyR� � s Rt c B s e Z d Z RS( s$ Connecting to the HTTP proxy failed.( RW RX RY ( ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyRt � s R� c B s e Z d Z RS( s# Invalid internal state encountered.( RW RX RY ( ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyR� � s (& RY RD R� R� t loggingRB R) R/ RM R` t getLoggerRW R* t __all__RG R� R� R. R| RH RF RK RL RJ R t _END_HEADERSR� R R� t objectR R t HTTPExceptionR, R� Rt R� R� ( ( ( sC /usr/lib64/python2.7/site-packages/mercurial/httpclient/__init__.pyt <module>& sB �� |