OwlCyberSecurity - MANAGER
Edit File: _newclient.pyc
� `��ac @` s d Z d d l m Z m Z e Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z m Z d d l m Z d d l m Z m Z m Z m Z d d l m Z d d l m Z d d l m Z d d l m! Z! m" Z" m# Z# d d l$ m% Z% d d l& m' Z' m( Z( d d l& m) Z) m* Z* d d l& m+ Z+ m, Z, d d l- m. Z. d Z/ d Z0 d Z1 d Z2 e. � Z3 d e4 f d � � YZ5 d e4 f d � � YZ6 d e4 f d � � YZ7 d e7 f d � � YZ8 d! e4 f d" � � YZ9 d# e9 f d$ � � YZ: d% e9 f d& � � YZ; d' e4 f d( � � YZ< d) e4 f d* � � YZ= d+ e4 f d, � � YZ> d- e9 f d. � � YZ? d/ e? f d0 � � YZ@ d1 e4 f d2 � � YZA d3 � ZB d4 e f d5 � � YZC d6 eC f d7 � � YZD e jE d8 eF � jG d9 d: d; d< d= d> d? d@ dA dB dC dD dE dF dG dH dI dJ f � f � ZH dK � ZI e jE dL � ZJ dM � ZK e e# � dN f dO � � Y� ZL dP f dQ � � YZM dR � ZN e e# � ZO e e" � dS f dT � � Y� ZP e e � dU f dV � � Y� ZQ e e � dW f dX � � Y� ZR dY e f dZ � � YZS d S([ s� An U{HTTP 1.1<http://www.w3.org/Protocols/rfc2616/rfc2616.html>} client. The way to use the functionality provided by this module is to: - Connect a L{HTTP11ClientProtocol} to an HTTP server - Create a L{Request} with the appropriate data - Pass the request to L{HTTP11ClientProtocol.request} - The returned Deferred will fire with a L{Response} object - Create a L{IProtocol} provider which can handle the response body - Connect it to the response with L{Response.deliverBody} - When the protocol's C{connectionLost} method is called, the response is complete. See L{Response.deliverBody} for details. Various other classes in this module support this usage: - HTTPParser is the basic HTTP parser. It can handle the parts of HTTP which are symmetric between requests and responses. - HTTPClientParser extends HTTPParser to handle response-specific parts of HTTP. One instance is created for each request to parse the corresponding response. i ( t divisiont absolute_importN( t implementer( t networkString( t proxyForInterface( t fullyQualifiedName( t Failure( t IConsumert IPushProducer( t ConnectionDone( t Deferredt succeedt failt maybeDeferred( t CancelledError( t Protocol( t LineReceiver( t UNKNOWN_LENGTHt IResponset IClientRequest( t Headers( t NO_CONTENTt NOT_MODIFIED( t _DataLosst PotentialDataLoss( t _IdentityTransferDecodert _ChunkedTransferDecoder( t Loggeru STATUSu HEADERu BODYu DONEt BadHeadersc B` s e Z d Z RS( s@ Headers passed to L{Request} were in some way invalid. ( t __name__t __module__t __doc__( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR = s t ExcessWritec B` s e Z d Z RS( sx The body L{IBodyProducer} for a request tried to write data after indicating it had finished writing data. ( R R R ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR D s t ParseErrorc B` s e Z d Z d � Z RS( sh Some received data could not be parsed. @ivar data: The string which could not be parsed. c C` s t j | | | � | | _ d S( N( t Exceptiont __init__t data( t selft reasonR$ ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR# Q s ( R R R R# ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR! K s t BadResponseVersionc B` s e Z d Z RS( s= The version string in a status line was unparsable. ( R R R ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR' W s t _WrapperExceptionc B` s e Z d Z d � Z RS( s, L{_WrapperException} is the base exception type for exceptions which include one or more other exceptions as the low-level causes. @ivar reasons: A L{list} of one or more L{Failure} instances encountered during an HTTP request. See subclass documentation for more details. c C` s t j | | � | | _ d S( N( R" R# t reasons( R% R) ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR# f s ( R R R R# ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR( ^ s t RequestGenerationFailedc B` s e Z d Z RS( s� There was an error while creating the bytes which make up a request. @ivar reasons: A C{list} of one or more L{Failure} instances giving the reasons the request generation was considered to have failed. ( R R R ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR* l s t RequestTransmissionFailedc B` s e Z d Z RS( s� There was an error while sending the bytes which make up a request. @ivar reasons: A C{list} of one or more L{Failure} instances giving the reasons the request transmission was considered to have failed. ( R R R ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR+ v s t ConnectionAbortedc B` s e Z d Z RS( sD The connection was explicitly aborted by application code. ( R R R ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR, � s t WrongBodyLengthc B` s e Z d Z RS( s� An L{IBodyProducer} declared the number of bytes it was going to produce (via its C{length} attribute) and then produced a different number of bytes. ( R R R ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR- � s t ResponseDonec B` s e Z d Z RS( s� L{ResponseDone} may be passed to L{IProtocol.connectionLost} on the protocol passed to L{Response.deliverBody} and indicates that the entire response has been delivered. ( R R R ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR. � s t ResponseFailedc B` s e Z d Z d d � Z RS( s� L{ResponseFailed} indicates that all of the response to a request was not received for some reason. @ivar reasons: A C{list} of one or more L{Failure} instances giving the reasons the response was considered to have failed. @ivar response: If specified, the L{Response} received from the server (and in particular the status code and the headers). c C` s t j | | � | | _ d S( N( R( R# t response( R% R) R0 ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR# � s N( R R R t NoneR# ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR/ � s t ResponseNeverReceivedc B` s e Z d Z RS( sU A L{ResponseFailed} that knows no response bytes at all have been received. ( R R R ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR2 � s t RequestNotSentc B` s e Z d Z RS( sF L{RequestNotSent} indicates that an attempt was made to issue a request but for reasons unrelated to the details of the request itself, the request could not be sent. For example, this may indicate that an attempt was made to send a request using a protocol which is no longer connected to a server. ( R R R ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR3 � s c C` s2 y | � Wn t j d d t | � �n Xd S( s� Call C{function}. If it raises an exception, log it with a minimal description of the source. @return: L{None} u Unexpected exception from {name}t nameN( t _moduleLogt failureR ( t function( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _callAppFunction� s t HTTPParserc B` s� e Z d Z d Z e d d d d d d d d g � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s L{HTTPParser} handles the parsing side of HTTP processing. With a suitable subclass, it can parse either the client side or the server side of the connection. @ivar headers: All of the non-connection control message headers yet received. @ivar state: State indicator for the response parsing state machine. One of C{STATUS}, C{HEADER}, C{BODY}, C{DONE}. @ivar _partialHeader: L{None} or a C{list} of the lines of a multiline header while that header is being received. s s content-lengtht connections keep-alivet tet trailerss transfer-encodingt upgrades proxy-connectionc C` s. t � | _ t � | _ t | _ d | _ d S( N( R t headerst connHeaderst STATUSt stateR1 t _partialHeader( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt connectionMade� s c C` s> | j t k r t d � � n | | _ t | _ | j � d S( s� Switch to body parsing mode - interpret any more bytes delivered as part of the message body and deliver them to the given decoder. u already in body modeN( RA t BODYt RuntimeErrort bodyDecodert setRawMode( R% t decoder( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt switchToBodyMode s c C` s� | d d k r | d } n | j t k rE | j | � t | _ n� | j t k r� | sk | d d k r� | j d k r� d j | j � } | j d d � \ } } | j � } | j | | � n | s� | j � q� | g | _ q� | j j | � n d S( s2 Handle one line from a response. i����s i s t t :i N( RA R@ t statusReceivedt HEADERRB R1 t joint splitt stript headerReceivedt allHeadersReceivedt append( R% t linet headerR4 t value( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt lineReceived s c C` s | j j | � d S( sM Pass data from the message body to the body decoder object. N( RF t dataReceived( R% R$ ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt rawDataReceived, s c C` s | | j k S( s� Return C{True} if the given lower-cased name is the name of a connection control header (rather than an entity header). According to RFC 2616, section 14.10, the tokens in the Connection header are probably relevant here. However, I am not sure what the practical consequences of either implementing or ignoring that are. So I leave it unimplemented for the time being. ( t CONNECTION_CONTROL_HEADERS( R% R4 ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt isConnectionControlHeader3 s c C` s d S( s Callback invoked whenever the first line of a new message is received. Override this. @param status: The first line of an HTTP request or response message without trailing I{CR LF}. @type status: C{bytes} N( ( R% t status( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyRL @ RJ c C` sD | j � } | j | � r' | j } n | j } | j | | � d S( s< Store the given header in C{self.headers}. N( t lowerR[ R? R> t addRawHeader( R% R4 RV R> ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyRQ K s c C` s | j d � d S( s� Callback invoked after the last header is passed to C{headerReceived}. Override this to change to the C{BODY} or C{DONE} state. N( RI R1 ( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyRR W s ( R R R t delimitert setRZ RC RI RW RY R[ RL RQ RR ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR9 � s t HTTPClientParserc B` s� e Z d Z e e e g � Z i e d 6Z d Z e � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( sL An HTTP parser which only handles HTTP responses. @ivar request: The request with which the expected response is associated. @type request: L{Request} @ivar NO_BODY_CODES: A C{set} of response codes which B{MUST NOT} have a body. @ivar finisher: A callable to invoke when this response is fully parsed. @ivar _responseDeferred: A L{Deferred} which will be called back with the response when all headers in the response have been received. Thereafter, L{None}. @ivar _everReceivedData: C{True} if any bytes have been received. t chunkedc C` s+ | | _ | | _ t � | _ t | _ d S( N( t requestt finisherR t _responseDeferredt Falset _everReceivedData( R% Rc Rd ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR# { s c C` s t | _ t j | | � d S( sM Override so that we know if any response has been received. N( t TrueRg R9 RX ( R% R$ ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyRX � s c C` s� yG | j d � \ } } | j d � \ } } t | � t | � } } Wn( t k rq } t t | � | � � n X| d k s� | d k r� t d | � � n | | | f S( s� Parse version strings of the form Protocol '/' Major '.' Minor. E.g. b'HTTP/1.1'. Returns (protocol, major, minor). Will raise ValueError on bad syntax. t /t .i u version may not be negative( RO t intt ValueErrorR' t str( R% t strversiont protot strnumbert majort minort e( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt parseVersion� s c C` s� | j d d � } t | � d k r9 | \ } } d } n3 t | � d k r] | \ } } } n t d | � � y t | � } Wn t k r� t d | � � n Xt j | j | � | | | j | j | j � | _ d S( s� Parse the status line into its components and create a response object to keep track of this response's state. t i RJ i u wrong number of partsu non-integer status codeN( RO t lenR! Rk Rl t Responset _constructRt R> t transportRc R0 ( R% R\ t partst versiont codeBytest phraset statusCode( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyRL � s$ c C` s t | _ | j | � d S( s� Called to indicate that an entire response has been received. No more bytes will be interpreted by this L{HTTPClientParser}. Extra bytes are passed up and the state of this L{HTTPClientParser} is set to I{DONE}. @param rest: A C{bytes} giving any extra bytes delivered to this L{HTTPClientParser} which are not part of the response being parsed. N( t DONERA Rd ( R% t rest( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _finished� s c C` s2 | j j d k r" | d k r" t St j | | � S( s� Content-Length in the response to a HEAD request is an entity header, not a connection control header. t HEADs content-length( Rc t methodRf R9 R[ ( R% R4 ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR[ � s c ` s� d | j j k o d k n rR | j j d d | j j �| j � | ` d S| j j | j k sy | j j d k r� d | j _ | j | j � � | j j � n| j j d � } | r� | j | d j � } n� | j j d � } | d k rd � n= t | � d k r2t | d � � � | j _ n t d � � � d k rf| j | j � � d } n � f d � } | d k r�| j j � n, | j j � | j | | j j | j � � | j j | j � | ` d S( sn Figure out how long the response body is going to be by examining headers and stuff. id i� s# Ignoring unexpected {code} responset codeNR� i s transfer-encodings content-lengthi u4 Too many Content-Length headers; response is invalidc ` s t � | | � S( N( R ( t xt y( t contentLength( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt <lambda> s ( R0 R� t _logt infoRC t NO_BODY_CODESRc R� t lengthR� t clearLineBuffert _bodyDataFinishedR? t getRawHeaderst _transferDecodersR] R1 Rv Rk Rl Ry t pauseProducingRI t _bodyDataReceivedRe t callback( R% t transferEncodingHeaderst transferDecodert contentLengthHeaders( ( R� sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyRR � sH " c C` s | j d k r� y� y | j j � Wn_ t k rI | j j t � � nI t k r� | j j t t | t � g | j � � � n X| j j � Wq� | j j d � q� XnO | j t k r� | j r� t } n t } | j j t | | g � � � | ` n d S( NRJ ( RF R1 t noMoreDataR R0 R� R R R/ R� R6 RA R Rg R2 Re t errback( R% R& t exceptionClass( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt connectionLost+ s& N( R R R R` R R R� R R� R1 RF R R� R# RX Rt RL R� R[ RR R� ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyRa ` s ! Vs \A[%s]+\Zt !t #t $t %t &t 't *t +t -Rj t ^t _t `t |t ~s 0-9s A-Zs a-zc C` s, t j | � r | St d j | � � � d S( s An HTTP method is an HTTP token, which consists of any visible ASCII character that is not a delimiter (i.e. one of C{"(),/:;<=>?@[\]{}}.) @param method: the method to check @type method: L{bytes} @return: the method if it is valid @rtype: L{bytes} @raise ValueError: if the method is not valid @see: U{https://tools.ietf.org/html/rfc7230#section-3.1.1}, U{https://tools.ietf.org/html/rfc7230#section-3.2.6}, U{https://tools.ietf.org/html/rfc5234#appendix-B.1} s Invalid method {!r}N( t _VALID_METHODt matchRl t format( R� ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _ensureValidMethodX s s \A[\x21-\x7e]+\Zc C` s, t j | � r | St d j | � � � d S( s A valid URI cannot contain control characters (i.e., characters between 0-32, inclusive and 127) or non-ASCII characters (i.e., characters with values between 128-255, inclusive). @param uri: the URI to check @type uri: L{bytes} @return: the URI if it is valid @rtype: L{bytes} @raise ValueError: if the URI is not valid @see: U{https://tools.ietf.org/html/rfc3986#section-3.3}, U{https://tools.ietf.org/html/rfc3986#appendix-A}, U{https://tools.ietf.org/html/rfc5234#appendix-B.1} s Invalid URI {!r}N( t _VALID_URIR� Rl R� ( t uri( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _ensureValidURIt s t Requestc B` s} e Z d Z e � Z e d � Z e e d d � � Z e d � � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s� A L{Request} instance describes an HTTP request to be sent to an HTTP server. @ivar method: See L{__init__}. @ivar uri: See L{__init__}. @ivar headers: See L{__init__}. @ivar bodyProducer: See L{__init__}. @ivar persistent: See L{__init__}. @ivar _parsedURI: Parsed I{URI} for the request, or L{None}. @type _parsedURI: L{twisted.web.client.URI} or L{None} c C` sF t | � | _ t | � | _ | | _ | | _ | | _ d | _ d S( st @param method: The HTTP method for this request, ex: b'GET', b'HEAD', b'POST', etc. @type method: L{bytes} @param uri: The relative URI of the resource to request. For example, C{b'/foo/bar?baz=quux'}. @type uri: L{bytes} @param headers: Headers to be sent to the server. It is important to note that this object does not create any implicit headers. So it is up to the HTTP Client to add required headers such as 'Host'. @type headers: L{twisted.web.http_headers.Headers} @param bodyProducer: L{None} or an L{IBodyProducer} provider which produces the content body to send to the remote HTTP server. @param persistent: Set to C{True} when you use HTTP persistent connection, defaults to C{False}. @type persistent: L{bool} N( R� R� R� R� R> t bodyProducert persistentR1 t _parsedURI( R% R� R� R> R� R� ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR# � s c C` s% | | | | | | � } | | _ | S( sS Private constructor. @param method: See L{__init__}. @param uri: See L{__init__}. @param headers: See L{__init__}. @param bodyProducer: See L{__init__}. @param persistent: See L{__init__}. @param parsedURI: See L{Request._parsedURI}. @return: L{Request} instance. ( R� ( t clsR� R� R> R� R� t parsedURIRc ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyRx � s c C` s t | j d d � � � S( s{ The absolute URI of the request as C{bytes}, or L{None} if the absolute URI cannot be determined. t toBytesc S` s d S( N( R1 ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� � RJ ( t getattrR� ( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt absoluteURI� s c C` s | j j d d � } t | � d k r6 t d � � n g } | j d j t | j � t | j � d g � � | j s� | j d � n | d k r� | j | � n xI | j j � D]8 \ } } | j g | D] } | d | d ^ q� � q� W| j d � | j | � d S( Nt hosti u Exactly one Host header requiredRu s HTTP/1.1 s Connection: close s : s ( ( R> R� Rv R RS RN R� R� R� R� R� R1 t getAllRawHeaderst extendt writeSequence( R% Ry t TEorCLt hostst requestLinesR4 t valuest v( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _writeHeaders� s" 0 c ` sv | j � d � t � � � � j | j t � | j j � � } � f d � } � � f d � } | j | | � | S( s� Write this request to the given transport using chunked transfer-encoding to frame the body. @param transport: See L{writeTo}. @return: See L{writeTo}. s Transfer-Encoding: chunked c ` s � j � d S( N( t unregisterProducer( t ignored( t encoder( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt cbProduced s c ` s � j � � j � | S( N( t _allowNoMoreWritesR� ( t err( R� Ry ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt ebProduced s ( R� t ChunkedEncodert registerProducerR� Rh t startProducingt addCallbacks( R% Ry t dR� R� ( ( R� Ry sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _writeToBodyProducerChunked� s c ` s� � j � t d � j j f � � t � } t � j � | � � � j � j t � � j j � � � � � � f d � } | | � � } � f d � } | j | � | S( s� Write this request to the given transport using content-length to frame the body. @param transport: See L{writeTo}. @return: See L{writeTo}. s Content-Length: %d c ` s� � f d � } t | � � d g � � � � f d � } � � � f d � } � � � � f d � } | j | � | j | | � � S( Nc ` s � j � d S( N( t cancel( t ign( t finishedProducing( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt cancelConsuming/ s c ` sY � d g k r) d � d <� j | � n, � j j d d | d t � � d � d �d S( Ni i u> Buggy state machine in {request}/[{state}]: ebConsuming calledR6 Rc RA ( R1 R� R� R6 t repr( R� ( R% RA t ultimate( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt ebConsuming9 s c ` sO � d g k rK d � d <y � j � Wn � j � qK X� j d � n d S( Ni i ( R1 t _noMoreWritesExpectedR� R� ( t result( R� RA R� ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt cbProducingP s c ` sM � d g k r3 d � d <� j � � j | � n � j j d d | �d S( Ni i u Producer is buggyR6 ( R1 R� R� R� R6 ( R� ( R� R% RA R� ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt ebProducinge s ( R R1 t addErrbackR� ( t consumingt producingR� R� R� R� ( R� R� R% ( RA R� sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt combine+ s c ` s � j � | S( N( R� ( t passthrough( Ry ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt f| s ( R� R R� R� R t LengthEnforcingConsumerR� Rh R� t addBoth( R% Ry t finishedConsumingR� R� R� ( ( R� R� R% Ry sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt! _writeToBodyProducerContentLength s P c C` s | j | d � t d � S( s� Write this request to the given transport using content-length to frame the (empty) body. @param transport: See L{writeTo}. @return: See L{writeTo}. s Content-Length: 0 N( R� R R1 ( R% Ry ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _writeToEmptyBodyContentLength� s c C` sq | j d k rA | j d k r. | j | � qm | j | d � n, | j j t k r` | j | � S| j | � Sd S( s Format this L{Request} as an HTTP/1.1 request and write it to the given transport. If bodyProducer is not None, it will be associated with an L{IConsumer}. @param transport: The transport to which to write. @type transport: L{twisted.internet.interfaces.ITransport} provider @return: A L{Deferred} which fires with L{None} when the request has been completely written to the transport or with a L{Failure} if there is any problem generating the request bytes. t PUTt POSTN( R� R� ( R� R1 R� R� R� R� R R� R� ( R% Ry ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt writeTo� s c C` s t | j j � d S( sR Stop writing this request to the transport. This can only be called after C{writeTo} and before the L{Deferred} returned by C{writeTo} fires. It should cancel any asynchronous task started by C{writeTo}. The L{Deferred} returned by C{writeTo} need not be fired if this method is called. N( R8 R� t stopProducing( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt stopWriting� s N( R R R R R� Rf R# t classmethodR1 Rx t propertyR� R� R� R� R� R� R� ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� � s w R� c B` s2 e Z d Z d � Z d � Z d � Z d � Z RS( s� An L{IConsumer} proxy which enforces an exact length requirement on the total data written to it. @ivar _length: The number of bytes remaining to be written. @ivar _producer: The L{IBodyProducer} which is writing to this consumer. @ivar _consumer: The consumer to which at most C{_length} bytes will be forwarded. @ivar _finished: A L{Deferred} which will be fired with a L{Failure} if too many bytes are written to this consumer. c C` s+ | j | _ | | _ | | _ | | _ d S( N( R� t _lengtht _producert _consumerR� ( R% t producert consumert finished( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR# � s c C` s d | _ d S( s� Indicate that no additional writes are allowed. Attempts to write after calling this method will be met with an exception. N( R1 R� ( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� � s c C` s� | j d k r( | j j � t � � n t | � | j k re | j t | � 8_ | j j | � n0 t | j j � | j j t d � � | j � d S( s� Write C{bytes} to the underlying consumer unless C{_noMoreWritesExpected} has been called or there are/have been too many bytes. u too many bytes writtenN( R� R1 R� R� R Rv R� R� t writeR8 R� R- R� ( R% t bytes( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� � s c C` s8 | j d k r4 | j � | j r4 t d � � q4 n d S( s� Called to indicate no more bytes will be written to this consumer. Check to see that the correct number have been written. @raise WrongBodyLength: If not enough bytes have been written. u too few bytes writtenN( R� R1 R� R� R- ( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� � s ( R R R R# R� R� R� ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� � s c ` s � f d � } | j | _ | S( s} Given a I{dispatch} name and a function, return a function which can be used as a method and which, when called, will call another method defined on the instance and return the result. The other method which is called is determined by the value of the C{_state} attribute of the instance. @param name: A string which is used to construct the name of the subsidiary method to invoke. The subsidiary method is named like C{'_%s_%s' % (name, _state)}. @param template: A function object which is used to give the returned function a docstring. @return: The dispatcher function. c ` sY t | d � d | j d � } | d k rL t d | � | j f � � n | | | � S( NR� u %r has no %s method in state %s( R� t _stateR1 RE ( R% t argst kwargst func( R4 ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt dispatcher s ! ( R ( R4 t templateR� ( ( R4 sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt makeStatefulDispatcher s Rw c B` s� e Z d Z e Z d Z e Z d � Z e d � � Z d � Z d � Z e d e � Z d � Z d � Z d � Z d � Z d � Z e d e � Z d � Z d � Z d � Z d � Z d d � Z e d e � Z d d � Z d d � Z d � Z d � Z RS( s A L{Response} instance describes an HTTP response received from an HTTP server. L{Response} should not be subclassed or instantiated. @ivar _transport: See L{__init__}. @ivar _bodyProtocol: The L{IProtocol} provider to which the body is delivered. L{None} before one has been registered with C{deliverBody}. @ivar _bodyBuffer: A C{list} of the strings passed to C{bodyDataReceived} before C{deliverBody} is called. L{None} afterwards. @ivar _state: Indicates what state this L{Response} instance is in, particularly with respect to delivering bytes from the response body to an application-supplied protocol object. This may be one of C{'INITIAL'}, C{'CONNECTED'}, C{'DEFERRED_CLOSE'}, or C{'FINISHED'}, with the following meanings: - INITIAL: This is the state L{Response} objects start in. No protocol has yet been provided and the underlying transport may still have bytes to deliver to it. - DEFERRED_CLOSE: If the underlying transport indicates all bytes have been delivered but no application-provided protocol is yet available, the L{Response} moves to this state. Data is buffered and waiting for a protocol to be delivered to. - CONNECTED: If a protocol is provided when the state is INITIAL, the L{Response} moves to this state. Any buffered data is delivered and any data which arrives from the transport subsequently is given directly to the protocol. - FINISHED: If a protocol is provided in the DEFERRED_CLOSE state, the L{Response} moves to this state after delivering all buffered data to the protocol. Otherwise, if the L{Response} is in the CONNECTED state, if the transport indicates there is no more data, the L{Response} moves to this state. Nothing else can happen once the L{Response} is in this state. @type _state: C{str} c C` sU | | _ | | _ | | _ | | _ | | _ g | _ d | _ d | _ d | _ d S( s� @param version: HTTP version components protocol, major, minor. E.g. C{(b'HTTP', 1, 1)} to mean C{b'HTTP/1.1'}. @param code: HTTP status code. @type code: L{int} @param phrase: HTTP reason phrase, intended to give a short description of the HTTP status code. @param headers: HTTP response headers. @type headers: L{twisted.web.http_headers.Headers} @param _transport: The transport which is delivering this response. t INITIALN( R{ R� R} R> t _transportt _bodyBufferR� R1 Rc t previousResponse( R% R{ R� R} R> R� ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR# [ s c C` s+ t | | | | | � } t | � | _ | S( sM Private constructor. @param version: See L{__init__}. @param code: See L{__init__}. @param phrase: See L{__init__}. @param headers: See L{__init__}. @param _transport: See L{__init__}. @param request: See L{IResponse.request}. @return: L{Response} instance. ( Rw t _ClientRequestProxyRc ( R� R{ R� R} R> R� Rc R0 ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyRx v s c C` s | | _ d S( N( R� ( R% R� ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt setPreviousResponse� s c C` s d S( si Dispatch the given L{IProtocol} depending of the current state of the response. N( ( R% t protocol( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt deliverBody� RJ R c C` s` | j | j � | | _ x! | j D] } | j j | � q# Wd | _ d | _ | j j � d S( s� Deliver any buffered data to C{protocol} and prepare to deliver any future data to it. Move to the C{'CONNECTED'} state. t CONNECTEDN( t makeConnectionR� t _bodyProtocolR� RX R1 R� t resumeProducing( R% R R$ ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _deliverBody_INITIAL� s c C` s t d | j f � � d S( s� It is invalid to attempt to deliver data to a protocol when it is already being delivered to another protocol. u: Response already has protocol %r, cannot deliverBody againN( RE R ( R% R ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _deliverBody_CONNECTED� s c C` sW | j | j � x | j D] } | j | � q Wd | _ | j | j � d | _ d S( s� Deliver any buffered data to C{protocol} and then disconnect the protocol. Move to the C{'FINISHED'} state. t FINISHEDN( R R� R� RX R1 R� t _reasonR� ( R% R R$ ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _deliverBody_DEFERRED_CLOSE� s c C` s t d � � d S( s� It is invalid to attempt to deliver data to a protocol after the response body has been delivered to another protocol. u2 Response already finished, cannot deliverBody now.N( RE ( R% R ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _deliverBody_FINISHED� s c C` s d S( s� Called by HTTPClientParser with chunks of data from the response body. They will be buffered or delivered to the protocol passed to deliverBody. N( ( R% R$ ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� � RJ t bodyDataReceivedc C` s | j j | � d S( s Buffer any data received for later delivery to a protocol passed to C{deliverBody}. Little or no data should be buffered by this method, since the transport has been paused and will not be resumed until a protocol is supplied. N( R� RS ( R% R$ ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _bodyDataReceived_INITIAL� s c C` s | j j | � d S( sk Deliver any data received to the protocol to which this L{Response} is connected. N( R RX ( R% R$ ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _bodyDataReceived_CONNECTED� s c C` s t d � � d S( s� It is invalid for data to be delivered after it has been indicated that the response body has been completely delivered. u0 Cannot receive body data after _bodyDataFinishedN( RE ( R% R$ ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _bodyDataReceived_DEFERRED_CLOSE� s c C` s t d � � d S( sz It is invalid for data to be delivered after the response body has been delivered to a protocol. u4 Cannot receive body data after protocol disconnectedN( RE ( R% R$ ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _bodyDataReceived_FINISHED� s c C` s d S( s� Called by HTTPClientParser when no more body data is available. If the optional reason is supplied, this indicates a problem or potential problem receiving all of the response body. N( ( R% R& ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� � RJ t bodyDataFinishedc C` s7 d | _ | d k r* t t d � � } n | | _ d S( s} Move to the C{'DEFERRED_CLOSE'} state to wait for a protocol to which to deliver the response body. t DEFERRED_CLOSEu Response body fully receivedN( R� R1 R R. R ( R% R& ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _bodyDataFinished_INITIAL s c C` sG | d k r! t t d � � } n | j j | � d | _ d | _ d S( sN Disconnect the protocol and move to the C{'FINISHED'} state. u Response body fully receivedR N( R1 R R. R R� R� ( R% R& ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _bodyDataFinished_CONNECTED s c C` s t d � � d S( s� It is invalid to attempt to notify the L{Response} of the end of the response body data more than once. u& Cannot finish body data more than onceN( RE ( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _bodyDataFinished_DEFERRED_CLOSE s c C` s t d � � d S( s� It is invalid to attempt to notify the L{Response} of the end of the response body data more than once. u3 Cannot finish body data after protocol disconnectedN( RE ( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _bodyDataFinished_FINISHED' s N( R R R R R� R1 R Rf t _bodyFinishedR# R� Rx R R R� R R R R R� R R R R R� R R R R ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyRw ( s6 , R� c B` s; e Z d Z d � Z d � Z d � Z d � Z d � Z RS( s� Helper object which exposes L{IConsumer} on top of L{HTTP11ClientProtocol} for streaming request bodies to the server. c C` s | | _ d S( N( Ry ( R% Ry ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR# 8 s c C` s d | _ d S( s� Indicate that no additional writes are allowed. Attempts to write after calling this method will be met with an exception. N( R1 Ry ( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� < s c C` s | j j | | � d S( sE Register the given producer with C{self.transport}. N( Ry R� ( R% R� t streaming( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� D s c C` sH | j d k r t � � n | j j t d t | � � | d f � d S( s� Write the given request body bytes to the transport using chunked encoding. @type data: C{bytes} s %x s N( Ry R1 R R� R Rv ( R% R$ ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� K s c C` s( | j d � | j j � | j � d S( sT Indicate that the request body is complete and finish the request. RJ N( R� Ry R� R� ( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� X s ( R R R R# R� R� R� R� ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� 1 s t TransportProxyProducerc B` sJ e Z d Z e Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s' An L{twisted.internet.interfaces.IPushProducer} implementation which wraps another such thing and proxies calls to it until it is told to stop. @ivar _producer: The wrapped L{twisted.internet.interfaces.IPushProducer} provider or L{None} after this proxy has been stopped. c C` s | | _ d S( N( R� ( R% R� ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR# t s c C` s d | _ d S( s� Stop forwarding calls of L{twisted.internet.interfaces.IPushProducer} methods to the underlying L{twisted.internet.interfaces.IPushProducer} provider. N( R1 R� ( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt stopProxyingx s c C` s# | j d k r | j j � n d S( sl Proxy the stoppage to the underlying producer, unless this proxy has been stopped. N( R� R1 R� ( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� � s c C` s# | j d k r | j j � n d S( sn Proxy the resumption to the underlying producer, unless this proxy has been stopped. N( R� R1 R ( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR � s c C` s# | j d k r | j j � n d S( si Proxy the pause to the underlying producer, unless this proxy has been stopped. N( R� R1 R� ( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� � s c C` s# | j d k r | j j � n d S( s� Proxy the request to lose the connection to the underlying producer, unless this proxy has been stopped. N( R� R1 t loseConnection( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR � s ( R R R Rf t disconnectingR# R R� R R� R ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR b s t HTTP11ClientProtocolc B` s� e Z d Z d Z d Z d Z d Z d Z d Z e � Z d � d � Z e d � � Z d � Z d � Z e d e � Z d � Z e Z d � Z d � Z d � Z d � Z e d e � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s( L{HTTP11ClientProtocol} is an implementation of the HTTP 1.1 client protocol. It supports as few features as possible. @ivar _parser: After a request is issued, the L{HTTPClientParser} to which received data making up the response to that request is delivered. @ivar _finishedRequest: After a request is issued, the L{Deferred} which will fire when a L{Response} object corresponding to that request is available. This allows L{HTTP11ClientProtocol} to fail the request if there is a connection or parsing problem. @ivar _currentRequest: After a request is issued, the L{Request} instance used to make that request. This allows L{HTTP11ClientProtocol} to stop request generation if necessary (for example, if the connection is lost). @ivar _transportProxy: After a request is issued, the L{TransportProxyProducer} to which C{_parser} is connected. This allows C{_parser} to pause and resume the transport in a way which L{HTTP11ClientProtocol} can exert some control over. @ivar _responseDeferred: After a request is issued, the L{Deferred} from C{_parser} which will fire with a L{Response} when one has been received. This is eventually chained with C{_finishedRequest}, but only in certain cases to avoid double firing that Deferred. @ivar _state: Indicates what state this L{HTTP11ClientProtocol} instance is in with respect to transmission of a request and reception of a response. This may be one of the following strings: - QUIESCENT: This is the state L{HTTP11ClientProtocol} instances start in. Nothing is happening: no request is being sent and no response is being received or expected. - TRANSMITTING: When a request is made (via L{request}), the instance moves to this state. L{Request.writeTo} has been used to start to send a request but it has not yet finished. - TRANSMITTING_AFTER_RECEIVING_RESPONSE: The server has returned a complete response but the request has not yet been fully sent yet. The instance will remain in this state until the request is fully sent. - GENERATION_FAILED: There was an error while the request. The request was not fully sent to the network. - WAITING: The request was fully sent to the network. The instance is now waiting for the response to be fully received. - ABORTING: Application code has requested that the HTTP connection be aborted. - CONNECTION_LOST: The connection has been lost. @type _state: C{str} @ivar _abortDeferreds: A list of C{Deferred} instances that will fire when the connection is lost. t QUIESCENTc C` s d S( N( R1 ( t c( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� � RJ c C` s | | _ g | _ d S( N( t _quiescentCallbackt _abortDeferreds( R% t quiescentCallback( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR# � s c C` s | j S( N( R� ( R% ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyRA � s c ` s� � j d k r t t � � Sd � _ t | j � j � � � � f d � } t | � � _ | � _ t � j � � _ t | � j � � _ � j j � j � � j j � _ � f d � } � f d � } � j | | � � j S( s� Issue C{request} over C{self.transport} and return a L{Deferred} which will fire with a L{Response} instance or an error. @param request: The object defining the parameters of the request to issue. @type request: L{Request} @rtype: L{Deferred} @return: The deferred may errback with L{RequestGenerationFailed} if the request was not fully written to the transport due to a local error. It may errback with L{RequestTransmissionFailed} if it was not fully written to the transport due to a network error. It may errback with L{ResponseFailed} if the request was sent (not necessarily received) but some or all of the response was lost. It may errback with L{RequestNotSent} if it is not possible to send any more requests using this L{HTTP11ClientProtocol}. R t TRANSMITTINGc ` sC � j d k r � j � n# � j j � � j t t � � � d S( NR% t% TRANSMITTING_AFTER_RECEIVING_RESPONSE( R% R& ( R� R� Ry t abortConnectiont _disconnectParserR R ( R� ( t _requestDeferredR% ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt cancelRequest s c ` s2 � j d k r. d � _ � j j � j � n d S( NR% t WAITING( R� Re t chainDeferredt _finishedRequest( R� ( R% ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt cbRequestWritten# s c ` sj � j d k rG d � _ � j j � � j j t t | g � � � n � j j d d | d � j �d S( NR% t GENERATION_FAILEDuJ Error writing request, but not in valid state to finalize request: {state}R6 RA ( R� Ry R' R- R� R R* R� R6 ( R� ( R% ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt ebRequestWriting( s ( R� R R3 R R� Ry R R- t _currentRequestR t _transportProxyRa t _finishResponset _parserR Re R� ( R% Rc R* R. R0 ( ( R) R% sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyRc � s c C` s d S( s! Called by an L{HTTPClientParser} to indicate that it has parsed a complete response. @param rest: A C{bytes} giving any trailing bytes which were given to the L{HTTPClientParser} which were not part of the response it was parsing. N( ( R% R� ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR3 ; RJ t finishResponsec C` s | j d k r d | _ n d | _ | j j | j � | j d k rJ d St d � } | j j j d d � } d | k s� | j d k s� | j j r� | j t | � � nR | j j � y | j | � Wn$ | j j d � | j j � n X| j | � d S( NR+ R R& u synthetic!R: t closeRJ ( ( R� Re R, R- R4 R1 R R? R� R1 R� t _giveUpR Ry R R" R� R6 R R( ( R% R� R& R? ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _finishResponse_WAITINGG s$ c C` sf | j d k rb | j } d | _ d | _ d | _ d | _ | j j � d | _ | j | � n d S( s� If there is still a parser, call its C{connectionLost} method with the given reason. If there is not, do nothing. @type reason: L{Failure} N( R4 R1 R1 R- Re R2 R R� ( R% R& t parser( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR( u s c C` s | j j � | j | � d S( s� Lose the underlying connection and disconnect the parser with the given L{Failure}. Use this method instead of calling the transport's loseConnection method directly otherwise random things will break. N( Ry R R( ( R% R& ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR7 � s c C` s2 y | j j | � Wn | j t � � n Xd S( s4 Handle some stuff from some place. N( R4 RX R7 R ( R% R� ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyRX � s c C` s d S( sh The underlying transport went away. If appropriate, notify the parser object. N( ( R% R& ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR� � RJ R� c C` s d | _ d S( s{ Nothing is currently happening. Move to the C{'CONNECTION_LOST'} state but otherwise do nothing. t CONNECTION_LOSTN( R� ( R% R& ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _connectionLost_QUIESCENT� s c C` s d | _ d S( s� The connection was in an inconsistent state. Move to the C{'CONNECTION_LOST'} state but otherwise do nothing. R: N( R� ( R% R& ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt! _connectionLost_GENERATION_FAILED� s c C` s? d | _ | j j t t | g � � � | ` | j j � d S( s� Fail the L{Deferred} for the current request, notify the request object that it does not need to continue transmitting itself, and move to the C{'CONNECTION_LOST'} state. R: N( R� R- R� R R+ R1 R� ( R% R& ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _connectionLost_TRANSMITTING� s c C` s d | _ d S( s9 Move to the C{'CONNECTION_LOST'} state. R: N( R� ( R% R& ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt5 _connectionLost_TRANSMITTING_AFTER_RECEIVING_RESPONSE� s c C` s | j | � d | _ d S( s Disconnect the response parser so that it can propagate the event as necessary (for example, to call an application protocol's C{connectionLost} method, or to fail a request L{Deferred}) and move to the C{'CONNECTION_LOST'} state. R: N( R( R� ( R% R& ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _connectionLost_WAITING� s c C` sM | j t t � � � d | _ x | j D] } | j d � q) Wg | _ d S( s� Disconnect the response parser with a L{ConnectionAborted} failure, and move to the C{'CONNECTION_LOST'} state. R: N( R( R R, R� R# R� R1 ( R% R& R� ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt _connectionLost_ABORTING� s c C` sL | j d k r t d � S| j j � d | _ t � } | j j | � | S( sw Close the connection and cause all outstanding L{request} L{Deferred}s to fire with an error. R: t ABORTINGN( R� R R1 Ry R R R# RS ( R% R� ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt abort� s N( R R R R� R1 R4 R- R1 R2 Re R R� R# R� RA Rc R3 R� R8 t _finishResponse_TRANSMITTINGR( R7 RX R� R; R< R= R> R? R@ RB ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyR � s6 < E + (T R t __future__R R t typet __metaclass__t ret zope.interfaceR t twisted.python.compatR t twisted.python.componentsR t twisted.python.reflectR t twisted.python.failureR t twisted.internet.interfacesR R t twisted.internet.errorR t twisted.internet.deferR R R R R t twisted.internet.protocolR t twisted.protocols.basicR t twisted.web.iwebR R R t twisted.web.http_headersR t twisted.web.httpR R R R R R t twisted.loggerR R@ RM RD R R5 R" R R R! R' R( R* R+ R, R- R. R/ R2 R3 R8 R9 Ra t compileR� RN R� R� R� R� R� R� R� R Rw R� R R ( ( ( sY /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/web/_newclient.pyt <module> s| " �� � 0J � 1 D