ProPeler
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
cpanel-ccs
/
txweb2
/
channel
/
Filename :
http.pyc
back
Copy
� �t�ac @ s� d d l Z d d l 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 m Z m Z d d l m Z m Z d d l m Z 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 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& e � Z' d e j( f d � � YZ) d e f d � � YZ* d d f \ Z+ Z, i Z- d � Z. d e/ f d � � YZ0 d e1 f d � � YZ2 d e/ f d � � YZ3 d e3 f d! � � YZ4 d" e j5 e j6 e/ f d# � � YZ7 d$ e j( f d% � � YZ8 d& e j9 f d' � � YZ: d( e: f d) � � YZ; d* e4 f d+ � � YZ< e< e7 _= d, e: f d- � � YZ> d& d( d, d g Z? d S(. i����N( t randint( t StringIO( t implements( t interfacest protocolt reactor( t succeedt Deferred( t policiest basic( t Logger( t responsecode( t http_headers( t http( t TLSCredentials( t RedirectResponse( t Request( t config( t accounting( t Certificate( t CertificateErrort OverloadedLoggingServerProtocolc B s e Z d � Z d � Z RS( c C s | | _ | | _ d S( N( t retryAftert outstandingRequests( t selfR R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt __init__8 s c C sg t j d | � | j j d � | j rF | j j d | j f � n | j j d � | j j � d S( Nt overloadeds; HTTP/1.0 503 Service Unavailable Content-Type: text/html s Retry-After: %s s� Connection: close <html><head><title>Service Unavailable</title></head><body><h1>Service Unavailable</h1>The server is currently overloaded, please try again later.</body></html>( t logt infot transportt writeR t loseConnection( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt connectionMade< s ( t __name__t __module__R R ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR 6 s t SSLRedirectRequestc B s e Z d Z d � Z RS( s} An L{SSLRedirectRequest} prevents processing if the request is over plain HTTP; instead, it redirects to HTTPS. c C s� | j j � \ } } | s� t j d k rC d t j | j f } n d t j t j | j f } t j d � t t | � j t | � � St t | � j � Sd S( Ni� s https://%s%ss https://%s:%d%ss Redirecting unsecured request( t chanRequestt getHostInfoR t SSLPortt ServerHostNamet uriR t debugt superR# t writeResponseR t process( R t ignoredt securet location( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR, Y s ( R! R" t __doc__R, ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR# S s i i c C s� t j | � } | d k r� y7 | d d !d k r> | d } n t j | � d } Wn# t j t j f k rw | } n X| t | <n | S( Ni i s ::ffff:( t _cachedHostNamest gett Nonet sockett gethostbyaddrt herrort gaierror( t hostaddrt hostname( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt _cachedGetHostByAddru s t StringTransportc B s) e Z d Z d � Z d � Z d � Z RS( sp I am a StringIO wrapper that conforms for the transport API. I support the 'writeSequence' method. c C s t � | _ d S( N( R t s( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR � s c C s | j j d j | � � d S( Nt ( R< R t join( R t seq( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt writeSequence� s c C s t | j d | � S( NR< ( t getattrt __dict__( R t attr( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt __getattr__� s ( R! R" R0 R R@ RD ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR; � s t AbortedExceptionc B s e Z RS( ( R! R" ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRE � s t HTTPParserc B s� e Z d Z e Z e Z d Z d Z d Z d Z d Z e Z d Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s� This class 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. i R= c C s t j � | _ | | _ d S( N( R t Headerst inHeaderst channel( R RI ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR � s c C s< | j r*| j d k r� | j d d � d } y t | d � | _ Wn | j t j d | � n X| j d k r� | j t j d � n | j d k r� d | _ q'| j j � q8| j d k r� | d k r� | j t j d t | � � n d | _ q8| j d k r8| d k r'| j � q'q8n| d k r�| j rR| j | j � n d | _ | j � | j � | j r{n) | j d k r�| j � n | j j � | j � n� | j t | � 7_ | j | j j k r�| j t j d � n | d d k r| j | 7_ n% | j r/| j | j � n | | _ d S( Ni t ;i i s) Invalid chunk size, not a hex number: %s!s Invalid chunk size, negative.i i R= s+ Excess %d bytes sent in chunk transfer modes Headers too long.s ( t chunkedInt splitt intt lengtht _abortWithErrorR t BAD_REQUESTRI t setRawModet lent allContentReceivedt partialHeadert headerReceivedt allHeadersReceivedt createRequestt processRequestt headerlent maxHeaderLength( R t linet chunksize( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt lineReceived� sN c C s� t | � } | | j k r; | j | � | j | | _ nV | j | | j � | | j } | j } | j s{ | j � n d | _ | j | � d S( s Handle incoming content.i N( RR RN t handleContentChunkRI RK RS t setLineMode( R t datat datalent extraneousRI ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt rawDataReceived s c C s� | j d d � } t | � d k r: | j t j d � n | \ } } xL | | f D]> } y | j d � WqS t k r� | j t j d � qS XqS W| j d � } | j j | | � d S( s� Store this header away. Check for too much header data (> channel.maxHeaderLength) and non-ASCII characters; abort the connection with C{BAD_REQUEST} if so. t :i i s No ':' in header.t asciis Headers must be ASCIIs N( RL RR RO R RP t decodet UnicodeDecodeErrort lstripRH t addRawHeader( R R[ t namevalt namet valt field( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRU s c C s& | j � } | j | � | | _ d S( N( t splitConnectionHeaderst setConnectionParamst connHeaders( R Rp ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRV - s c C s' t | _ | j j | � | j � d S( N( t Truet finishedReadingRI t requestReadFinishedt handleContentComplete( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRS 5 s c s� � � f d � } d d d d d d d d g } | j � t j � � | d � | j d k r� xU � j d d � D]% } � j | � rq � j | � qq qq Wn | j � j d d � � | j d k r� | j d � n x | D] } | | � q� W� S( sw Split off connection control headers from normal headers. The normal headers are then passed on to user-level code, while the connection headers are stashed in .connHeaders and used for things like request/response framing. This corresponds roughly with the HTTP RFC's description of 'hop-by-hop' vs 'end-to-end' headers in RFC2616 S13.5.1, with the following exceptions: - proxy-authenticate and proxy-authorization are not treated as connection headers. - content-length is, as it is intimately related with low-level HTTP parsing, and is made available to user-level code via the stream length, rather than a header value. (except for HEAD responses, in which case it is NOT used by low-level HTTP parsing, and IS kept in the normal headers. c sB � j | d � } | d k r> � j | � � j | | � n d S( N( t getRawHeadersR3 t removeHeadert setRawHeaders( Rk t h( Rp RH ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt moveP s s content-lengtht connections keep-alivet tet trailerss transfer-encodingt upgrades proxy-connectioni ( i i ( ( N( RH R RG t versiont getHeadert hasHeaderRv t extendRN R3 t remove( R Ry t connHeaderNamesRk t headername( ( Rp RH s& /opt/cpanel-ccs/txweb2/channel/http.pyRn : s" c C si | j d k r9 d | j d d � k r0 t } q` t } n' d | j d d � k rZ t } n t } | j d � } | r� | d d k r� d | _ | d } n | j s� | j t j d � n | rU| j t j d | � qUnx d | _ | j r@| j t j k r d | _ n | j d | j � | _ | j d k rUt } qUn | j d d � | _ | j j | � d S( Ni t closeRz s keep-alives transfer-encodingi����t chunkeds< Transfer-Encoding received without chunked in last position.s# Transfer-Encoding %s not supported.i s content-length( i i ( ( ( R~ R t Falset PERSIST_PIPELINEt PERSIST_NO_PIPELINERK t parseCloseAsEndRO R RP t NOT_IMPLEMENTEDt codeR t NO_BODY_CODESRN R3 RI t setReadPersistent( R Rp t readPersistentt transferEncoding( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRo | s2 c C s9 | j s5 t | _ | j j t � | j j | � n d S( N( Rr Rq RI R� R� Rs ( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt abortParse� s c C s | j s | j j � n d S( N( Rr RI t pauseProducing( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s c C s | j s | j j � n d S( N( Rr RI t resumeProducing( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s c C s | j s | j j � n d S( N( Rr RI t stopProducing( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s N( R! R" R0 R� R� RK RY R3 RN RH RT Rp Rr RI R R] Rc RU RV RS Rn Ro R� R� R� R� ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRF � s, C B 9 t HTTPChannelRequestc B s e Z d Z d Z Z Z d Z d Z d Z d d � Z d � Z e d � Z d � Z d � Z d � Z d � Z d Z e Z e Z d d � Z d � Z d � Z d � Z d � Z e d � Z d � Z d � Z d d � Z d � Z d � Z d � Z! d � Z" d � Z# RS( s This class handles the state and parsing for one HTTP request. It is responsible for all the low-level connection oriented behavior. Thus, it takes care of keep-alive, de-chunking, etc., and passes the non-connection headers on to the user-level Request object.i s HTTP/1.1c C sJ t j | | � | | _ | r. t � | _ n | j j | _ d | _ d S( Ni i ( i i ( RF R t queuedR; R RI R~ ( R RI R� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR � s c C s_ | j � } t | � d k r� t | � d k r@ | j d � n t | � d k rv | d d d k rv | j d � q� | j t j d | � n | \ | _ | _ } y/ t j | � } | d d k r� t � � n Wn( t k r� | j t j d | � n X| d d !| _ | j d d k r8| j t j d � n | j d d k r[| j d � n d S( Ni i t /i i s HTTP/0.9s Bad request line: %sR s Unknown protocol: %ss) Only HTTP 0.9 and HTTP 1.x are supported.R= ( RL RR t appendRO R RP t commandt pathR t parseVersiont ValueErrorR~ t HTTP_VERSION_NOT_SUPPORTEDR] ( R t initialLinet partst strversiont protovers( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt gotInitialLine� s& & c C s, | r t j p t j } | j | d � d S( Ns Header line too long.( R t REQUEST_URI_TOO_LONGRP RO ( R R[ t wasFirstR� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt lineLengthExceeded s c C s= | j j | | j | j | j | j | j � | _ | ` d S( N( RI t requestFactoryR� R� R~ RN RH t request( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRW s 3c C s | j j � d S( N( R� R, ( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRX s c C s | j j | � d S( N( R� R^ ( R R` ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR^ s c C s | j j � d S( N( R� Rt ( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRt s c C s) | j d k r% | j | | t � n d S( Ni ( i i ( R~ t _writeHeadersR� ( R R� t headers( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt writeIntermediateResponse s c C s | j | | t � d S( N( R� Rq ( R R� R� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt writeHeaders s c C s� | j d d k r d Sg } t j j | d � } | j d | j | | f � | d k r� xE | j � D]4 \ } } x% | D] } | j d | | f � q{ Wqh Wn | rd| j d � d k r| j d k r| t j k r| j d k r| j d d � t | _ q| j j � n | j j | � r>| j d d � qd| j d k rd| j d d � qdn | j d � | j j | � d S( Ni s Unknown Statuss %s %s %s s %s: %s s content-lengtht HEADi s Transfer-EncodingR� t ConnectionR� s Keep-Alives ( i i ( s Transfer-EncodingR� ( R� R� ( i i ( R� s Keep-Alive( R~ R t RESPONSESR2 R� t out_versionR3 t getAllRawHeadersR R� R R� Rq t chunkedOutRI t dropQueuedRequestst isLastRequestR R@ ( R R� R� t addConnectionHeaderst lt code_messageRk t valuelistt value( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� s. " c C sM | s d S| j r9 | j j d t | � | d f � n | j j | � d S( Ns %X s ( R� R R@ RR R ( R R` ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR E s &c C s_ | j r t j d d d �d S| j r< | j j d � n t | _ | j s[ | j � n d S( s We are finished writing data.s% Warning! request.finish called twice.t stackleveli Ns 0 ( t finishedt warningst warnR� R R Rq R� t _cleanup( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt finishM s c C ss | j � | ro | j r3 | j j � | j � n t | _ | j rb | j j � | j j � qo | j � n d S( sh Abort the HTTP connection because of some kind of unrecoverable error. If closeWrite=False, then only abort reading, but leave the writing side alone. This is mostly for internal use by the HTTP request parsing logic, so that it can call an error page generator. Otherwise, completely shut down the connection. N( R� t producerR� t unregisterProducerRq R� R� R t resett truncateR� ( R t closeWrite( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt abortConnection[ s c C s | j j | j j f S( N( RI t _hostt _secure( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR% q s c C s | j j j � S( N( RI R t getPeer( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt getRemoteHostt s R= c C s� t j � } | j d t | � d � | j d t � | j | | � | j | � | j d � | j � t j d | | f � t � d S( s! Handle low level protocol errors.s content-lengthi R� s s Aborted request (%d) %sN( R RG t setHeaderRR R� R� R� R R� R R� RE ( R t errorcodet textR� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRO y s c C sG | j r- t j t d | � � | j � n | j j | � | ` d S( s> Called when have finished responding and are no longer queued.s$ Producer was not unregistered for %sN( R� R t errort RuntimeErrorR� RI t requestWriteFinishedR ( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s c C s� | j s t d � n d | _ | j j � } | j j | _ | rU | j j | � n | j d k r� | j r� | j j | j t � n | j r� | j � n d S( s� Notify the object that it is no longer queued. We start writing whatever data we have to the transport, etc. This method is not intended for users. s* noLongerQueued() got called unnecessarily.i N( R� R� R t getvalueRI R R� R3 R� t registerProducerRq R� ( R R` ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt noLongerQueued� s c C sX | j r" t d | | j f � n | | _ | j rA | j � n | j j | | � d S( s Register a producer. sA registering producer %s before previous one (%s) was unregisteredN( R� R� R� R� R R� ( R R� t streaming( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s c C s& | j s | j j � n d | _ d S( s Unregister the producer.N( R� R R� R3 R� ( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s c C sK | j r+ | j r+ | j j � d | _ n | j rG | j j | � n d S( s connection was lostN( R� R� R� R3 R� t connectionLost( R t reason( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s N($ R! R" R0 R3 R� R� R~ R� R� R� R R� R� R� RW RX R^ Rt R� R� R� R� R� R� R R� Rq R� R% R� RO R� R� R� R� R� ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s: % t HTTPChannelc B s e Z d Z e e j � d Z d Z d Z d Z d Z d Z e Z e Z e j Z d Z e Z e Z e Z d Z d Z e Z d Z d � Z d � Z d � Z d � Z! d � Z" d � Z# d � Z$ d � Z% d � Z& d � Z' d � Z( d � Z) d � Z* d � Z+ d � Z, d � Z- d � Z. RS( s� A receiver for HTTP requests. Handles splitting up the connection for the multiple HTTPChannelRequests that may be in progress on this channel. @ivar timeOut: number of seconds to wait before terminating an idle connection. @ivar maxPipeline: number of outstanding in-progress requests to allow before pausing the input. @ivar maxHeaderLength: number of bytes of header to accept from the client. i i i< i i i ( i c C s t j | | � d S( N( R t callLater( R t secst fun( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt _callLater� s c C s g | _ d S( N( t requests( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR s c C sc t j | j d � d k | _ | j j � } t | j � | _ | j | j � | j j | � d S( N( R t ISSLTransportR R3 R� t getHostR: t hostR� t setTimeoutt inputTimeOutt factoryt addConnectedChannel( R t address( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR s c C sL | j r? y t t j | j � � | _ Wq? t k r; q? Xn t | _ d S( N( R� R R t peerFromTransportR t peerCredentialsR Rq t peerCertificateCheck( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt processPeerCertificate s c C s" | j r | j r | j � n | j r� | j | j � | j sY d � | _ | _ d S| r| | j d k r| d | _ d Sd | _ | j s� t | _ n yE | j | t | j � � | _ | j j | j � | j j | � Wq t k r� q Xn( y | j j | � Wn t k r n Xd S( Nc W s d S( N( R3 ( t args( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt <lambda> R= i i i ( R� R� R� t _first_lineR� R� R� t dataReceivedR] t allowPersistentConnectionsR� t chanRequestFactoryRR R� R$ R� R� RE ( R R[ ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR] s. c C s | j rM | j | t | j � � | _ | j j | j � | j j d � n y | j j | | j � Wn t k rz n Xd S( Ns GET fake HTTP/1.0( R� R� RR R� R$ R� R� R� RE ( R R[ ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� ; s c C s< | j | j � y | j j | � Wn t k r7 n Xd S( N( R� R� R$ Rc RE ( R R` ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRc G s c C s| | j t k s' t | j � | j k r4 | j � n d | _ d | _ | j � t | j � d k rx | j | j � n d S( Ni i ( R� R� RR R� t maxPipelineR� R� R3 R$ R_ R� t idleTimeOut( R R� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRs N s c C s� | j d =| j r# | j j � n� | j r~ | j d j � | j r� | j t k r� t | j � | j k r� | j � q� n3 | j r� | j j � n | j | j � | j � d S( Ni ( R� t _writeLostR R R� t _readLostR� R� RR R� R� R� t betweenRequestsTimeOut( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt _startNextRequest] s c C s | j r | | _ n d S( N( R� ( R t persistent( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� s s c C s< t | _ x" | j d D] } | j d � q W| j d 3d S( sA Called when a response is written that forces a connection close.i N( R� R� R� R� R3 ( R R� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� x s c C s | j o | j d | k S( Ni����( R� R� ( R R� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s c C s� | | j d k r t � n d | j d <| j sG t | j � d k r] | j d | j � n5 | j d � t j | j | j � | _ | j j � d S( s1 Called by first request in queue when it is done.i i N( R� t TypeErrorR3 R� RR R� R� R� R R� t closeTimeOutt _abortTimeoutt _abortTimerR R ( R R� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s c C s/ t j | j | j � | _ t j j | � d S( N( R R� R� R� R� R t TimeoutMixint timeoutConnection( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s c C s< t j d d t | j j � � �d | _ | j j � d S( Ns0 Connection aborted - took too long to close: {c}t c( R R� t strR R� R3 R� R� ( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s " c C so | j r0 | j j � d | _ | j j � d St | _ | j sR | j j � n | j rk | j j � n d S( s Read connection lostN( R� t cancelR3 R R Rq R� R� R$ ( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt readConnectionLost� s c C sd | j j | � t | _ | j � | j d � x- | j D]" } | d k r: | j | � q: q: Wd S( N( R� t removeConnectedChannelRq R� R� R� R3 R� R� ( R R� R� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s i� i, N(/ R! R" R0 R R t IHalfCloseableProtocolR� R� R� R� R� RZ Rq R� R� R� R R R� R� R� R� R� R� R� R3 R� R$ R� R� R� R R R� R] R� Rc Rs R� R� R� R� R� R� R� R� R� ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � sH % t OverloadedServerProtocolc B s e Z d � Z RS( c C s! | j j d � | j j � d S( Ns� HTTP/1.0 503 Service Unavailable Content-Type: text/html Connection: close <html><head><title>503 Service Unavailable</title></head><body><h1>Service Unavailable</h1>The server is currently overloaded, please try again later.</body></html>( R R R ( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR � s ( R! R" R ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR � s t HTTPFactoryc B sY e Z d Z e Z d Z d d � Z d � Z d � Z d � Z e d � � Z d � Z RS( s, Factory for HTTP server. @ivar outstandingRequests: the number of currently connected HTTP channels. @type outstandingRequests: C{int} @ivar connectedChannels: all the channels that have currently active connections. @type connectedChannels: C{set} of L{HTTPChannel} iX c K s8 | | _ | | _ | | j d <t � | _ d | _ d S( NR� ( t maxRequestst protocolArgst sett connectedChannelsR3 t allConnectionsClosedDeferred( R R� R t kwargs( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR � s c C sb | j | j k r t � St j j | | � } x- | j j � D] \ } } t | | | � q> W| S( N( R R R R t ServerFactoryt buildProtocolR t iteritemst setattr( R t addrt pt argR� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR � s c C s | j j | � d S( s� Add a connected channel to the set of currently connected channels and increase the outstanding request count. N( R t add( R RI ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s c C sH | j j | � | j d k rD | j d k rD | j j d � qD n d S( s[ Remove a connected channel from the set of currently connected channels and decrease the outstanding request count. If someone is waiting for all the requests to be completed, self.allConnectionsClosedDeferred will be non-None; fire that callback when the number of outstanding requests hits zero. i N( R R� R R3 R t callback( R RI ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s c C s t | j � S( N( RR R ( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR s c C s, | j d k r t d � St � | _ | j S( s� Return a Deferred that will fire when all outstanding requests have completed. @return: A Deferred with a result of None i N( R R R3 R R ( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt allConnectionsClosed s N( R! R" R0 R� R R3 R R R R� R� t propertyR R ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR � s t HTTP503LoggingFactoryc B s) e Z d Z d d e d � Z d � Z RS( sM Factory for HTTP server which emits a 503 response when overloaded. iX i c K s, | | _ | | _ t j | | | | � d S( N( R t varyR R ( R R� R R R R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR s c C s� | j r= t t | j d d � t | j d d � � } n | j } | j | j k rh t | | j � St j j | | � } x- | j j � D] \ } } t | | | � q� W| S( Ni i i ( R R RM R R R R R R R R R R ( R R R R R R� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR $ s 4 ( R! R" R0 R� R R ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR s t HTTPLoggingChannelRequestc B sv e Z d e f d � � YZ d e f d � � YZ d d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( t TransportLoggingWrapperc B s, e Z d � Z d � Z d � Z d � Z RS( c C s | | _ | | _ d S( N( R t logData( R R R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR 9 s c C s< | j d k r( | r( | j j | � n | j j | � d S( N( R R3 R� R R ( R R` ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR > s c C sE | j d k r1 | r1 | j j d j | � � n | j j | � d S( NR= ( R R3 R� R> R R@ ( R R? ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR@ C s c C s t | j d | � S( NR ( RA RB ( R RC ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRD H s ( R! R" R R R@ RD ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR 7 s t LogDatac B s e Z d � Z RS( c C s g | _ g | _ d S( N( R� t response( R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR M s ( R! R" R ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR K s i c C se t t | � j | | � t j d � rX t j � | _ t j | j | j j � | _ n d | _ d S( Nt HTTP( R* R R R t accountingEnabledForCategoryR R R R R R3 ( R RI R� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR Q s !c C sr | j d k rX t j � | _ | j j j d | j f � | j j j d | f � n t t | � j | � d S( Ns" >>>> Request starting at: %.3f s %s ( R R3 t timet startTimeR� R� R* R R� ( R R� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� Z s c C s� | j d k r� | } | j � j d � r� | d j � j d � } | d j � d k r� t | � d k r� d | d | d d t | d � f } q� n | j j j d | f � n t t | � j | � d S( Ns authorization:i t i R i s %s %s %st Xi s %s ( R R3 t lowert startswitht stripRL RR R� R� R* R R] ( R R[ t loggedLinet bits( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR] a s (/ c C s? | j d k r% | j j j | � n t t | � j | � d S( N( R R3 R� R� R* R R^ ( R R` ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR^ m s c C s] | j d k rF t j � } | j j j d | d | | j f � n t t | � j � d S( Ns5 >>>> Request complete at: %.3f (elapsed: %.1f ms)i� ( R R3 R R� R� R R* R Rt ( R t doneTime( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyRt s s +c C sc | j d k rF t j � } | j j j d | d | | j f � n t t | � j | | � d S( Ns9 <<<< Response sending at: %.3f (elapsed: %.1f ms) i� ( R R3 R R R� R R* R R� ( R R� R� R% ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� z s +c C s� t t | � j � | j d k r� t j � } | j j j d | d | | j f � t j d d d j | j j � d j | j j � | j � n d S( Ns8 <<<< Response complete at: %.3f (elapsed: %.1f ms) i� R R= ( R* R R� R R3 R R R� R R t emitAccountingR> R� R� ( R R% ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s (( R! R" t objectR R R R� R] R^ Rt R� R� ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR 5 s t LimitingHTTPFactoryc B s8 e Z d Z d d d � Z d � Z d � Z d � Z RS( s� HTTPFactory which stores maxAccepts on behalf of the MaxAcceptPortMixin @ivar myServer: a reference to a L{MaxAcceptTCPServer} that this L{LimitingHTTPFactory} will limit. This must be set externally. iX id c K s# t j | | | | � | | _ d S( N( R R t maxAccepts( R R� R R) R ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR � s c C sI t j j | | � } x- | j j � D] \ } } t | | | � q% W| S( s� Override L{HTTPFactory.buildProtocol} in order to avoid ever returning an L{OverloadedServerProtocol}; this should be handled in other ways. ( R R R R R R ( R R R R R� ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR � s c C s9 t j | | � | j | j k r5 | j j j � n d S( s� Override L{HTTPFactory.addConnectedChannel} to pause listening on the socket when there are too many outstanding channels. N( R R� R R t myServert myPortt stopReading( R RI ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s c C s9 t j | | � | j | j k r5 | j j j � n d S( s� Override L{HTTPFactory.removeConnectedChannel} to resume listening on the socket when there are too many outstanding channels. N( R R� R R R* R+ t startReading( R RI ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR� � s ( R! R" R0 R R R� R� ( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyR( � s (@ R R� R4 t randomR t cStringIOR t zope.interfaceR t twisted.internetR R R t twisted.internet.deferR R t twisted.protocolsR R t twext.python.logR t txweb2R R R t txweb2.auth.tlsR t txweb2.httpR t txweb2.serverR t twistedcaldav.configR t twistedcaldavR t twisted.internet._sslverifyR t twisted.internet.errorR R t ProtocolR R# R� R� R1 R: R' R; t ExceptionRE RF R� t LineReceiverR� R� R R R R R R� R( t __all__( ( ( s& /opt/cpanel-ccs/txweb2/channel/http.pyt <module> sR � 5�"� GT *