gj0dZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlmZddlmZmZmZddlmZddlmZddlmZdd lmZmZd Z e jBd k(Z" ejFd d jIdZ% e" xre% Z& e&r ddl'Z'ddl(Z(ddl*Z*e"r)e+edr e+edsde_,e+edsde_-e+eds erdnde_.dZ/dZ0dZ1dZ2dZ3dZ4dZ5d Z6d!Z7d"Z8ejrdjud#e8fZ;e<Z=gd$Z>e+e d%sie _?Gd&d'Z@Gd(d)e@ZAGd*d+ZBGd,d-ZCGd.d/ZDGd0d1ZEGd2d3ZFGd4d5ZGGd6d7ZHd8d9d:ZId serve() while ready: _connections.run() while not stop_requested: child = socket.accept() # blocks until a request comes in conn = HTTPConnection(child, ...) server.process_conn(conn) # adds conn to threadpool Worker threads are kept in a pool and poll the Queue, popping off and then handling each connection in turn. Each connection can consist of an arbitrary number of requests and their responses, so we run a nested loop:: while True: conn = server.requests.get() conn.communicate() -> while True: req = HTTPRequest(...) req.parse_request() -> # Read the Request-Line, e.g. "GET /page HTTP/1.1" req.rfile.readline() read_headers(req.rfile, req.inheaders) req.respond() -> response = app(...) try: for chunk in response: if chunk: req.write(chunk) finally: if hasattr(response, "close"): response.close() if req.close_connection: return For running a server you can invoke :func:`start() ` (it will run the server forever) or use invoking :func:`prepare() ` and :func:`serve() ` like this:: server = HTTPServer(...) server.prepare() try: threading.Thread(target=server.serve).start() # waiting/detecting some appropriate stop condition here ... finally: server.stop() And now for a trivial doctest to exercise the test suite .. testsetup:: from cheroot.server import HTTPServer >>> 'HTTPServer' in globals() True N) lru_cache) connectionserrors __version__)bton)IS_PPC) threadpool)MakeFile StreamWriter) HTTPRequestHTTPConnection HTTPServer HeaderReaderDropUnderscoreHeaderReaderSizeCheckWrapperKnownLengthRFile ChunkedRFileGatewayget_ssl_adapter_classWindowsSERVER_SOFTWAREzGoogle App Engine/F)NNAF_INET6 IPPROTO_IPV6) IPV6_V6ONLY SO_PEERCRED s   :;*/s%2Fs(?i))sAcceptsAccept-CharsetsAccept-EncodingsAccept-Languages Accept-RangessAllows Cache-Control ConnectionsContent-EncodingsContent-LanguageExpectsIf-Matchs If-None-MatchsPragmasProxy-AuthenticatesTEsTrailerTransfer-EncodingsUpgradesVarysViasWarningsWWW-Authenticate statisticsc$eZdZdZddZdZdZy)rz`Object for reading headers from an HTTP request. Interface and default implementation. Nc|i} |j}|s td|tk(r |S|jts td|ddtt fvr|j }n= |jtd\}}|j }|j|}|}|js|tvr&|j}|rdj||f}||<#t$r tdwxYw)a Read headers from the given stream into the given header dict. If hdict is None, a new header dict is created. Returns the populated header dict. Headers which are repeated are folded together using a comma if their specification so dictates. This function raises ValueError when the read bytes violate the HTTP spec. You should probably return "400 Bad Request" if this happens. NIllegal end of headers.HTTP requires CRLF terminatorsrzIllegal header line.s, )readline ValueErrorCRLFendswithSPACETABstripsplitCOLON_transform_key _allow_headercomma_separated_headersgetjoin)selfrfilehdictlinevkhnameexistings #/opt/Tautulli/lib/cheroot/server.py__call__zHeaderReader.__call__s =E>>#D !:;;t|: 9==& !ABBBQxE3<' JJL=::eQ/DAqGGI''*%%a(++ 99U+ Ha=1AE%LG,"=$%;<<=s 2C44D cy)NTr@key_names rHr<zHeaderReader._allow_headersr'c>|jjSN)r8titlerLs rHr;zHeaderReader._transform_keys~~%%''r'rO)__name__ __module__ __qualname____doc__rIr<r;rKr'rHrrs 6p(r'rc"eZdZdZfdZxZS)rzDCustom HeaderReader to exclude any headers with underscores in them.c:tt| |}|xrd|vS)N_)superrr<)r@rMorig __class__s rHr<z(DropUnderscoreHeaderReader._allow_headers%/DXN+8++r')rQrRrSrTr< __classcell__)rZs@rHrrsN,,r'rcJeZdZdZdZdZd dZd dZd dZdZ d Z d Z e Z y) rzWraps a file-like object, raising MaxSizeExceeded if too large. :param rfile: ``file`` of a limited size :param int maxlen: maximum length of the file being read c.||_||_d|_y)z%Initialize SizeCheckWrapper instance.rN)rAmaxlen bytes_read)r@rAr^s rH__init__zSizeCheckWrapper.__init__s  r'cx|jr.|j|jkDrtjyyrO)r^r_rMaxSizeExceededr@s rH _check_lengthzSizeCheckWrapper._check_length s. ;;4??T[[8((* *9;r'Nc|jj|}|xjt|z c_|j |S)Read a chunk from ``rfile`` buffer and return it. :param size: amount of data to read :type size: int :returns: chunk from ``rfile``, limited by size if specified :rtype: bytes )rAreadr_lenrdr@sizedatas rHrgzSizeCheckWrapper.reads9zzt$ 3t9$  r'c|K|jj|}|xjt|z c_|j |Sg} |jjd}|xjt|z c_|j |j |t|dks |ddt k(rtj|S)Read a single line from ``rfile`` buffer and return it. :param size: minimum amount of data to read :type size: int :returns: one line from ``rfile`` :rtype: bytes N) rAr2r_rhrdappendLFEMPTYr?)r@rjrkress rHr2zSizeCheckWrapper.readlines  ::&&t,D OOs4y (O    K::&&s+D OOs4y (O    JJt 4y3$rs)r/zz#&r'cd}g}|j|}|rB|j||t|z }d|cxkr|kr |S|j|}|rB|SzRead all lines from ``rfile`` buffer and return them. :param sizehint: hint of minimum amount of data to read :type sizehint: int :returns: lines of bytes read from ``rfile`` :rtype: list[bytes] rr2rprhr@sizehinttotallinesrCs rH readlineszSizeCheckWrapper.readlines9m}}X& LL  SY E8$u$ %==*D   r'c8|jjyz*Release resources allocated for ``rfile``.NrAclosercs rHrzSizeCheckWrapper.closeN r'c|SzReturn file iterator.rKrcs rH__iter__zSizeCheckWrapper.__iter__R r'ct|j}|xjt|z c_|j |SzGenerate next file chunk.)nextrAr_rhrdr@rks rH__next__zSizeCheckWrapper.__next__Vs3DJJ 3t9$  r'rOr) rQrRrSrTr`rdrgr2r{rrrrrKr'rHrrs6  + '6* Dr'rcDeZdZdZdZd dZd dZd dZdZdZ d Z e Z y) rzWraps a file-like object, returning an empty string when exhausted. :param rfile: ``file`` of a known size :param int content_length: length of the file being read c ||_||_y)z%Initialize KnownLengthRFile instance.N)rA remaining)r@rAcontent_lengths rHr`zKnownLengthRFile.__init__gs 'r'Nc|jdk(ry| |j}nt||j}|jj|}|xjt |zc_|S)zRead a chunk from ``rfile`` buffer and return it. :param size: amount of data to read :type size: int :rtype: bytes :returns: chunk from ``rfile``, limited by size if specified rr')rminrArgrhris rHrgzKnownLengthRFile.readlsZ >>Q  <>>DtT^^,Dzzt$ #d)# r'c|jdk(ry| |j}nt||j}|jj|}|xjt |zc_|S)rmrr')rrrAr2rhris rHr2zKnownLengthRFile.readlines\ >>Q  <>>DtT^^,Dzz""4( #d)# r'cd}g}|j|}|rB|j||t|z }d|cxkr|kr |S|j|}|rB|Srurvrws rHr{zKnownLengthRFile.readlinesr|r'c8|jjyr~rrcs rHrzKnownLengthRFile.closerr'c|SrrKrcs rHrzKnownLengthRFile.__iter__rr'clt|j}|xjt|zc_|Sr)rrArrhrs rHrzKnownLengthRFile.__next__s'DJJ #d)# r'rOr) rQrRrSrTr`rgr2r{rrrrrKr'rHrr`s1 ( ((* Dr'rcBeZdZdZd dZdZd dZd dZd dZdZ d Z y) raWraps a file-like object, returning an empty string when exhausted. This class is intended to provide a conforming wsgi.input value for request entities that have been encoded with the 'chunked' transfer encoding. :param rfile: file encoded with the 'chunked' transfer encoding :param int maxlen: maximum length of the file being read :param int bufsize: size of the buffer used to read the file c`||_||_d|_t|_||_d|_y)z!Initialize ChunkedRFile instance.rFN)rAr^r_rrbufferbufsizeclosed)r@rAr^rs rHr`zChunkedRFile.__init__s,     r'c|jry|jj}|xjt |z c_|j r9|j|j kDr t jd|j |jjtd} |jd}t|d}|dkrd|_y|j r'|j|z|j kDr td|jj!|}|xjt |z c_|xj"|z c_|jj!d}|t$k7rtd t'|zd zy#t$rtdjwxYw) NRequest Entity Too Largerrz)Bad chunked transfer size: {chunk_size!r}) chunk_sizeTz2Bad chunked transfer coding (expected '\r\n', got ))rrAr2r_rhr^rrbr8r9 SEMICOLONpopintr3formatIOErrorrgrr4repr)r@rCrchunkcrlfs rH_fetchzChunkedRFile._fetchsy ;; zz""$ 3t9$ ;;4??T[[8((*DKK zz|!!)Q/ !JZ,J ?DK  ;;4??Z7$++E45 5  + 3u:% u zzq! 4<d$&)*  ) ;*-  s 0F%F?Nc:t}|dk(r|S |rt||k\r|S|js|j|js|S|r5|t|z }||jd|z }|j|d|_n||jz }t|_)rfrN)rrrhrr)r@rjrkrs rHrgzChunkedRFile.reads 19KD T) ;; {{K 3t9,  JY//"kk)*5  ## !r'cZt}|dk(r|S |rt||k\r|S|js|j|js|S|jj t }|ry|dk(r5|t|z }||jd|z }|j|d|_nt |t|z |}||jd|z }|j|d|_nF|dk(r||jz }t|_n&||jd|z }|j|d|_)rmrroN)rrrhrrfindrqr)r@rjrk newline_posrs rHr2zChunkedRFile.readlines  19KD T) ;; {{K++**2.K"$ $s4y 0IDKK 33D"&++ij"9DK #D3t9$4k BIDKK 33D"&++ij"9DK"$DKK'D"'DKDKK 55D"&++kl";DK5r'cd}g}|j|}|rB|j||t|z }d|cxkr|kr |S|j|}|rB|Srurvrws rHr{zChunkedRFile.readlinesDr|r'c#K|js td |jj}|s td|xjt |z c_|j r$|j|j kDr td|tk(ry|jts td|w)zhRead HTTP headers and yield them. :yields: CRLF separated lines :ytype: bytes z:Cannot read trailers until the request body has been read.r0rr1N) rr3rAr2r_rhr^rr4r5)r@rCs rHread_trailer_lineszChunkedRFile.read_trailer_linesYs{{L ::&&(D !:;; OOs4y (O{{t<899t|==& !ABBJ!sB=B?c8|jjyr~rrcs rHrzChunkedRFile.closewrr')i rOr) rQrRrSrTr`rrgr2r{rrrKr'rHrrs- )V$@( --chhs|.DEI9B 6GZYE !c!999Y78  $$%8 ) )I%* *F *R(  )')( #C$$%H  -}55-,,  >2 $$%6=$$%7|$$%2  055d;LL11!4 $$U+D}- 4'D   DK" %%a( )3t{{/C/CA/F+G G a5BqE>  !A B ,!-B !;SJ'   !24L M &   !24K L 6  b $$%6 C sm4A P.5P.60P.5%Q/ Q6R 2&RR .!QQQ32Q36 RRR R=R88R=c` |j|j|j|j j} t|jjdd}|r||kDr|j ddy|jd k(r'|jjd d d k(r.d |_ n&|jjd d dk7rd |_ d}|jd k(rh|jjd}|rK|jdDcgc]1}|js|jj3}}d|_|r-|D](}|dk(rd |_|j dd |_ y|jjdd dk(rld j!|j j"j%dt&dt(t(f} |j*j,j/|y y #t$r)}|j d|j dYd}~yd}~wwxYw#t$r|j ddYywxYwcc}w#t0j2$r*}|j dt4j6vrYd}~y d}~wwxYw)zRead ``self.rfile`` into ``self.inheaders``. Ref: :py:attr:`self.inheaders `. :returns: success status :rtype: bool rrNFContent-Lengthz Malformed Content-Length Header.rCThe entity sent with the request exceeds the maximum allowed bytes.HTTP/1.1r*r'closeT Keep-Aliver,,chunkedz501 Unimplementedr+s 100-continueasciis 100 Continue) header_readerrArr3rrrmax_request_body_sizerr>rrr9r8lowerrr?rencoder6r4rwfilewritesocketerrorrsocket_errors_to_ignore)r@rmrbsclterencmsgs rHrz HTTPRequest.read_request_headerssu    tzz4>> : {{00 T^^''(91=>B BI  .!    ! !Z /~~!!-5A(,%~~!!-5F(,%  ! !Z /##$89B13$MA1779aggioo'MM!  !*$(,D%(()<=,0D)  !6 >>  i - @(( $$++G4e_dC  %%c*g   !2BGGAJ ?    !2   <NT<< 771:V%C%CCD sL&H%I I+1 I+.%I0 III I('I(0J- J((J-cf|jj}|jr&t|jj ||_npt |jjdd}|r$||kr|js|jddyt|jj ||_|jj|j|jxr|j|j r&|jj"j%dyy)z/Call the gateway and write its iterable output.rrrrNs0 )rrrrrrArrr>rrrgatewayrespondrensure_headers_sentrr r )r@rrs rHrzHTTPRequest.respond(s{{00   %diiootBr ((((61 )$))//2>DJ D!))+ 1t//1    IIOO ! !, / r'ct|}|jjd|d}dt|z}d}|j d|j d|j dg}|dddvr*d |_|j d k(r|jd nd }|jt|r2t|tr|j d}|j| |jjjtj|y#tj $r*}|j"d t$j&vrYd}~yd}~wwxYw)z+Write a simple response back to the client. z zContent-Length: %s zContent-Type: text/plain ISO-8859-1N)413414TrsConnection: close rr)strrrrhrrrrpr4 isinstancerr r rrr?r r rrr )r@rr proto_statusr content_typebufrs rHrzHTTPRequest.simple_response?s'V&*kk&:&:FC 1CH<5    -  ! !, /    -  "1: '$(D !%%3 34+ 4 #s#jj. JJsO  IIOO ! !%**S/ 2|| wwqz!?!??@ s%8DE1 EEcL|jsd|_|jyy)z:Ensure headers are sent to the client if not already sent.TN)r send_headersrcs rHrzHTTPRequest.ensure_headers_sentds$  $D     !r'cD|jro|rmtt|ddjd}|t|tg}|j j jtj|y|j j j|y)z$Write unbuffered data to the client.rNr) rhexrhrr4rr r rrr?)r@rchunk_size_hexr!s rHr zHTTPRequest.writejsn   % U_QR077@N!45C IIOO ! !%**S/ 2 IIOO ! !% (r'c|jDcgc]\}}|j}}}t|jdd}|dk(rd|_nZd|vrV|dks|dvrnL|j dk(xr|j d k7}|r#d|_|jjd nd|_|js|jj}| |_d |vr^|j dk(r(|jrC|jjd n'|js|jjd d |jvrP|jjddj|jjjdf|jsC|js7t|j dd}|dkDr|j j#|d|vrJ|jjdt$j&j)djdfd|vr@|jjd|jj*jdf|jj,jd}|t.z|jzt0zg} |jD].\} } | j| t2zt.z| zt0z0| jt0|j4j6j9t:j=| ycc}}w)zAssert, process, and send the HTTP response message-headers. You must set ``self.status``, and :py:attr:`self.outheaders ` before calling this. NriTscontent-length)i0rsHEAD)r,rs connection)r*r)r*rrztimeout={connection_timeout})connection_timeoutrrrsdatesDate)usegmtsserversServerr)rrrrrrrrrprcan_add_keepalive_connectionrtimeoutrrgetattrrArgemailutils formatdate server_namerr6r4r:rr r rrr?) r@keyvaluehkeysr needs_chunkedcan_keeprprotor!rErDs rHr#zHTTPRequest.send_headersss 04?e??T[[!_% S=$(D ! e +|v8**j8/ w.!)-D&OO**+MN-1D)$${{??H(0LD !  %%%3((OO**+DE,,OO**+IJ )T__ < OO " "/$++*=*=>|$ $ %%0A0A  K;I1}  * %  OO " " &&d&3::<H$  E ! OO " " ''..|<$   $$++G4u}t{{*T12OO 5DAq JJq5y5(1,t3 4 5 4 ejjo.g@sM)FT)r)rQrRrSrTrrrrrrrrrr`rrrrrrr r#rKr'rHr r |s F@ DDI$J; E@M<!NM'B DaF^@0.#J )Y/r'r ceZdZdZdZdZdZejZ ejZ e Z dZ dZdZefdZdZdZdZdZdZd Zed Zed Zed Zd ZedZedZdZy)rz#An HTTP connection (active socket).NFc||_||_||d|j|_||d|j|_d|_|jj|_|jj|_td|j|_ td|j|_ y)aBInitialize HTTPConnection instance. Args: server (HTTPServer): web server object receiving this request sock (socket._socketobject): the raw socket object (usually TCP) for this connection makefile (file): a fileobject class for reading from the socket rbwbrr)maxsizeN) rr rbufsizerAwbufsizer  requests_seenpeercreds_enabledpeercreds_resolve_enabledrresolve_peer_credsget_peer_creds)r@rsockmakefiles rHr`zHTTPConnection.__init__s  dD$--8 dD$--8 !%!>!>)-)N)N& !Ia !8!8 9  !Ia !4!4 5 r'cd} |j|j|}|j|jjdr|xjdz c_|j syd}|j |jsy y#tj$r}|jd}d}||vr#|rr{|jro|jdn\|tjvrJ|jjdt!|zt"j$d |jd Yd }~yd }~wt&t(f$rtj*$rYytj,$r|j/Yyt0$rQ}|jjt!|t"j2d |jd Yd }~yd }~wwxYw) zrRead each request and respond appropriately. Returns true if the connection should be kept open. FEnabledrTr)z timed outzThe read operation timed outz408 Request Timeoutzsocket.error %slevel tracebackz500 Internal Server ErrorN)RequestHandlerClassrrstatsrArrrr r rr_conditional_errorrr  error_logrloggingWARNINGKeyboardInterrupt SystemExit FatalSSLAlert NoSSLError_handle_no_ssl ExceptionERROR)r@ request_seenreqrerrnum timeout_errss rH communicatezHTTPConnection.communicates  * F**4;;=C    {{  +""a'"99L KKM''(<9|| JWWQZFFL% %##2E2E++C1FGv=== %%%V 4!//T&''-HI":.  ##     %    $   F KK ! !R  "   # #C)D E E  Fs8A&B +B GBD88%G#GG AGGc|r |jry |jj}t |d|j |_d}|jd|d|_ y#t$r|jj}YYwxYw)Nr=zUThe client sent a plain HTTP request, but this server only speaks HTTPS on this port.rT) rr _sockAttributeError_socketr r@r rlinger)r@r[ resp_sockrs rHrWzHTTPConnection._handle_no_ssl.s~c&&  , ))I")T4==A  :  -s3  , ++I ,sABBc|r |jry |j|y#tj$rYytj$r|j |YywxYw)zvRespond with an error. Don't bother writing if a response has already started being written. N)rrrrUrVrW)r@r[responses rHrOz!HTTPConnection._conditional_error?sY c&&  %    )##     %    $ %s#A#AAc|jj|js+|j|jjyy)z,Close the socket underlying this connection.N)rArrc_close_kernel_socketr rcs rHrzHTTPConnection.closeOs< {{  % % ' KK    r'cd}ts'|jjtjk7r t d|j s t d |jjtjtjtj|}tj||\}}}|||fS#tj$r } t |d}~wwxYw)aReturn the PID/UID/GID tuple of the peer socket for UNIX sockets. This function uses SO_PEERCRED to query the UNIX PID, UID, GID of the peer, which is only available if the bind address is a UNIX domain socket. Raises: NotImplementedError: in case of unsupported socket type RuntimeError: in case of SO_PEERCRED lookup unsupported or disabled 3iz5SO_PEERCRED is only supported in Linux kernel and WSLz0Peer creds lookup is disabled within this serverN) IS_WINDOWSr familyAF_UNIXNotImplementedErrorrB RuntimeError getsockopt SOL_SOCKETrstructcalcsizeunpackr )r@PEERCRED_STRUCT_DEF peer_credspiduidgid socket_errs rHrEzHTTPConnection.get_peer_credsbs# ++v~~=%G ''B  !//!!6#5#5 34 J #MM*=zJMCcS= || / J . /sA B>>CCCc.|j\}}}|S)z,Return the id of the connected peer process.rE)r@rwrWs rHpeer_pidzHTTPConnection.peer_pids'') Q r'c.|j\}}}|S)z1Return the user id of the connected peer process.r|)r@rWrxs rHpeer_uidzHTTPConnection.peer_uids'') 3 r'c.|j\}}}|S)z2Return the group id of the connected peer process.r|)r@rWrys rHpeer_gidzHTTPConnection.peer_gids'') 1c r'cts td|js tdt j |j j}tj|jj}||fS)aLook up the username and group tuple of the ``PEERCREDS``. :returns: the username and group tuple of the ``PEERCREDS`` :raises NotImplementedError: if the OS is unsupported :raises RuntimeError: if UID/GID lookup is unsupported or disabled zUID/GID lookup is unavailable under current platform. It can only be done under UNIX-like OS but not under the Google App Enginez-UID/GID lookup is disabled within this server) IS_UID_GID_RESOLVABLErnrCropwdgetpwuidrpw_namegrpgetgrgidrgr_name)r@usergroups rHrDz!HTTPConnection.resolve_peer_credssp%%6  //? ||DMM*22 T]]+33U{r'c,|j\}}|S)z2Return the username of the connected peer process.rD)r@rrWs rH peer_userzHTTPConnection.peer_users))+a r'c,|j\}}|S)z/Return the group of the connected peer process.r)r@rWrs rH peer_groupzHTTPConnection.peer_groups**,5 r'c*t|jd|jj} |tjy#tj $rYytj $r'}|jtjvrYd}~yd}~wwxYw)z0Terminate the connection at the transport level. sock_shutdownN) r/r shutdown SHUT_RDWRr#acceptable_sock_shutdown_exceptionsr errno$acceptable_sock_shutdown_error_codes)r@res rHrhz#HTTPConnection._close_kernel_socketsw KK KK     V%% &99  || wwfIIIJ sABB+B  B) rQrRrSrT remote_addr remote_portssl_envioDEFAULT_BUFFER_SIZEr?r@r rMrBrC last_usedr r`r^rcrWrOrrEpropertyr}rrrDrrrhrKr'rHrrs-KKG%%H%%H% %I.6 61fF"% &)!V   0  r'rceZdZdZdZdZdZ dZ dZ dZ dZ dZ dZ dZ dZ dje Z dZ d Z d Z d Z d Z eZ dZ d Z d Z d Z dZ d&d ZdZdZ dZ!e"dZ#e#jHdZ#dZ%dZ&dZ'dZ(e)jTdZ+e"dZ,dZ-d'dZ.d(dZ/dZ0e1dZ2e3 d)dZ4e1dZ5e1d Z6d!Z7e"d"Z8e"d#Z9e8jHd$Z8d%Z:y)*rzAn HTTP server.z 127.0.0.1Nrr g?zCheroot/{version!s})versionFrTc ||_||_tj||xsd||_|s |j }||_||_|xr||_||_ |jy)aInitialize HTTPServer instance. Args: bind_addr (tuple): network interface to listen to gateway (Gateway): gateway for processing HTTP requests minthreads (int): minimum number of threads for HTTP thread pool maxthreads (int): maximum number of threads for HTTP thread pool server_name (str): web server name to be advertised via Server HTTP header reuse_port (bool): if True SO_REUSEPORT option would be set to socket r)rmaxN) bind_addrrr ThreadPoolrequestsrr3rBrC reuse_port clear_stats) r@rr minthreads maxthreadsr3rBrCrs rHr`zHTTPServer.__init__3ss$# "-- joA:  ,,K&!2 % ;*; &% r'cd_d_idddfddfdd dd fd d fd dfddfddddddddddddddddi_jtjd t z<y)!zReset server stat counters..NrrIFz Bind Addressc.tjSrO)rrsr@s rHz(HTTPServer.clear_stats..\sd4>>&:r'zRun timec<|d xrdxsjS)NrIroruntimers rHrz(HTTPServer.clear_stats..]sq|#3";"Mt||~r'Acceptsz Accepts/secc0|djz S)Nrrrs rHrz(HTTPServer.clear_stats.._sQy\DLLN%Br'Queuec2tjddS)Nqsizer/rrs rHrz(HTTPServer.clear_stats..`swt}}gtDr'ThreadscDttjdgS)N_threads)rhr/rrs rHrz(HTTPServer.clear_stats..asWT]]J%K!Lr'z Threads Idlec2tjddS)Nidlerrs rHrz(HTTPServer.clear_stats..bsgdmmVT&Jr'z Socket ErrorsRequestscb|d xrdxs$td|djDdS)NrIroc32K|]}|d|yw)rNrK.0ws rH z;HTTPServer.clear_stats....esHa:q!HWorker Threadsrsumvaluesrs rHrz(HTTPServer.clear_stats..ds8q|#3";#sH1-=+>+E+E+GH!@r' Bytes Readcb|d xrdxs$td|djDdS)NrIroc32K|]}|d|yw)rNrKrs rHrz;HTTPServer.clear_stats....hsJ<#Jrrrrrs rHrz(HTTPServer.clear_stats..gs89%5$=2%JQ/?-@-G-G-IJABr' Bytes Writtencb|d xrdxs$td|djDdS)NrIroc32K|]}|d|yw)rNrKrs rHrz;HTTPServer.clear_stats....ksM1#?#A&Mrrrrrs rHrz(HTTPServer.clear_stats..js9AiL(8'@b(CM2B0C0J0J0LMEr' Work Timecb|d xrdxs$td|djDdS)NrIroc32K|]}|d|yw)rNrKrs rHrz;HTTPServer.clear_stats....osIq;"Irrrrrs rHrz(HTTPServer.clear_stats..ns8) $4#<"$IA.>,?,F,F,HI1Ar'zRead Throughputcb|d xrdxs$td|djDdS)NrIroc3RK|]}|d||d|xsdz !yw)rrư>NrKrs rHrz;HTTPServer.clear_stats....rs8$AlOA&.!K.*;*CtD%'rrrrs rHrz(HTTPServer.clear_stats..qs@a l*:)B*c/0779 Gr'zWrite Throughputcb|d xrdxs$td|djDdS)NrIroc3RK|]}|d||d|xsdz !yw)rrrNrKrs rHrz;HTTPServer.clear_stats....xs9'Ao&q)^Q{^A->-F$Grrrrrs rHrz(HTTPServer.clear_stats..ws@q|+;*C+s/0779 Hr'rzCheroot HTTPServer %d) _start_time _run_timerNrQr-idrcs`rHrzHTTPServer.clear_statsVs$ u$ :$  M$  q $ B $ D $  L$  J$  Q$  $  $ !$ ( )$ .  /$ : !;$ F bG$  JBF2RX=>r'c|j |jS|jtj|jz zS)zReturn server uptime.)rrtimercs rHrzHTTPServer.runtimes8    #>> !>>TYY[43C3C%CD Dr'ch|jd|jjd|jdS)z1Render Server instance representing bind address..(r)rRrZrQrrcs rH__str__zHTTPServer.__str__s( OOT^^44 NN  r'c|jS)aReturn the interface on which to listen for connections. For TCP sockets, a (host, port) tuple. Host values may be any :term:`IPv4` or :term:`IPv6` address, or any valid hostname. The string 'localhost' is a synonym for '127.0.0.1' (or '::1', if your hosts file prefers :term:`IPv6`). The string '0.0.0.0' is a special :term:`IPv4` entry meaning "any active interface" (INADDR_ANY), and '::' is the similar IN6ADDR_ANY for :term:`IPv6`. The empty string or :py:data:`None` are not allowed. For UNIX sockets, supply the file name as a string. Systemd socket activation is automatic and doesn't require tempering with this variable. .. glossary:: :abbr:`IPv4 (Internet Protocol version 4)` Internet Protocol version 4 :abbr:`IPv6 (Internet Protocol version 6)` Internet Protocol version 6 ) _bind_addrrcs rHrzHTTPServer.bind_addrs4r'cVt|tr|ddvr td||_y)z5Set the interface on which to listen for connections.r)rNzzHost values of '' or None are not allowed. Use '0.0.0.0' (IPv4) or '::' (IPv6) instead to listen on all active interfaces.N)rrr3r)r@r5s rHrzHTTPServer.bind_addrs6 eU #aJ(>6   r'c |jy#t$r}|j}|s||_||d}~wt$r}|j}|s||_||d}~wwxYw)z4Run the server forever, and stop it cleanly on exit.N)startrS interruptrT)r@ kb_intr_excunderlying_interrupt sys_exit_excs rH safe_startzHTTPServer.safe_startsc 9 JJL  8#'>> '!,#7 7 9#'>> '!-$8 8  9s A4 AAAcd|_|jd|jz|_d|_d}t j ddr9tj dtjtj|_nt|jttfr |j|jnx|j\}} tj||tj tjd tj"}|D]}|\} } } } } |j)| | | n|jstj||jj-d |jj/|j0t3j4||_|j8j;d|_t?j>|_ y#tj$r0}|d|jd|d}tj||d}~wwxYw#tj$$rOtj}|j}d |vrtj&}|d z}|tjd d |fg}YwxYw#tj$rC}|d| d|d}|jr|jj+d|_Yd}~d}~wwxYw)zPrepare server to serving requests. It binds a socket's port, setups the socket to ``listen()`` and does other preparing things. Nz %s ServerzNo socket could be created LISTEN_PIDrz -- (z: rr:)rrrrT)! _interruptsoftwarerr osgetenvfromfdAF_INET SOCK_STREAMrrrbytesbind_unix_socketr  getaddrinfo AF_UNSPEC AI_PASSIVEgaierrorrbindr settimeoutlistenrequest_queue_sizerConnectionManager _connectionsrrrrr)r@rserrhostrinfo sock_typerrsafsocktyper9 _canonnamesas rHpreparezHTTPServer.preparesZ  == '$,,6DM * 99\4 ( --6>>6;M;MNDK e 5 2%%dnn5JD$ K))$ 0 0&&6+<+< '693HeZ'IIb(E2 '{{,,s# # q! 4223(99$?  99;a<< 2*-t~~tDll3'T1 2?? K"NN  NN $; &I )F 2I"F$6$62yIJ K||'.12t+H))H.1AJJK,)8K''K,c|jrK|js? |jj|j|jr |js?|jrG|jr"tjd|jr"|jr |jyy#t t f$rt$r%|jdtjdYwxYw)z1Serve requests, after invoking :func:`prepare()`.zError in HTTPServer.serveTrJg?N)rrrrunexpiration_intervalrSrTrXrPrQrY_stopping_for_interruptrsleeprcs rHservezHTTPServer.servesjj !!%%d&>&>?jj >>.. 3..~~nn$ &z2  /w}}" s%B,,:C)(C)cD|j|jy)zmRun the server forever. It is shortcut for invoking :func:`prepare()` then :func:`serve()`. N)r rrcs rHrzHTTPServer.start+s  r'c#K|jtj|j}d|_|j  ||j y#|j wxYww)z4Context manager for running this server in a thread.)targetTN)r  threadingThreadrdaemonrstop)r@threads rH_run_in_threadzHTTPServer._run_in_thread7sQ !!4   L IIKDIIKsAA5 A A5 A22A5cJ|jxr|jjS)z>Flag whether it is allowed to add a new keep-alive connection.)rrr-rcs rHr-z'HTTPServer.can_add_keepalive_connectionCszzLd//LLLr'ct|jr|jj|y|jy)z7Put an idle connection back into the ConnectionManager.N)rrputrr@rs rHput_connzHTTPServer.put_connHs( ::    ! !$ ' JJLr'cFtjjdj|tjj |rRt j }tjj|tjj yy)zWrite error message to log. Args: msg (str): error message level (int): logging level traceback (bool): add traceback to output or not z{msg!s} )rN)sysstderrr rflush traceback_ format_exc)r@rrKrLtbliness rHrPzHTTPServer.error_logPsl +++45   ++-G JJ  W % JJ    r'c |j|j||||j|j|j}|j ||jx}|_|j||_|S)z.Create (or recreate) the actual socket object.)prepare_socketrnodelayrr bind_socketr resolve_real_bind_addr)r@rltyper9rFs rHrzHTTPServer.bind`sl"" NN D% LL$** OO   "--dDNNCCt{44T: r'c tr tdd} tj|j|j|tjtjd|j|j|j } tj|j!|d } |j#||}|j)|} |s tj*||d }|s!|j1d t2j4||_||_ |S#t $rYt $r}t|}d|vrYd}~d}~wt$r#}t|}d|vr d|vrd|vrYd}~Ad}~wwxYw#t $rd }YwxYw#tj$$r|j'wxYw#t,$rtj.||d YwxYw#t $rYwxYw)z*Create (or recreate) a UNIX socket object.z0AF_UNIX sockets are not supported under Windows.izJremove() argument 1 must be encoded string without null bytes, not unicodeNz'unlink: embedded null character in pathzembedded null bytez0argument must be a string without NUL charactersr)rrlr-r9r*rrTF)follow_symlinksz(Failed to set socket fs mode permissions)rK)rkr3runlinkrOSError TypeErrorrr)r rmrr*rrfchmodfilenor+r rr,lchmodrachmodrPrQrR)r@rfs_permissionstyp_errerr_msgval_errrF FS_PERMS_SETs rHrzHTTPServer.bind_unix_socketls  B   IIdnn %0"">>(:(:!LLd.>.> #  ! B IIdkkm^ 4L ##D)4D //5   COIIi8 $  NN:oo   #  C   'lG="# #  'lG(/67,G;4;BC . ! L ! ||  JJL  &OHHYNO   s}D#'E>0FGF7.G# E;.E;6E  E;E66E;> F  F %F47!GGGG G*)G*c&|dd\}}|dk(}|jtjtjfvr t d|r t dt tdr0|j tjtjdyt tdr0|j tjtjdytr0|j tjtjdytd) NrrzCannot reuse a non-IP socketz"Cannot reuse an ephemeral port (0)SO_REUSEPORT_LBr SO_REUSEPORTz,Current platform does not support port reuse) rlr rrr3hasattr setsockoptrqr=r>rk SO_REUSEADDRrn)socket_rrrIS_EPHEMERAL_PORTs rH_make_socket_reusablez HTTPServer._make_socket_reusablesr] d AI >>&..&//!B B;< < AB B 6, -   v00&2H2H! L V^ ,   v00&2E2Eq I    v00&2E2Eq I%> r'ctj|||}tj||dd\} } | dk(} |r|j||ts2| s0 |j tj tjd|rEt|ttfs/|j tjtjd||j|}ttdxr|tjk(xr| dv} | r2 |j tj tj"d|S|S#t$tj&f$rY|SwxYw)z%Create and prepare the socket object.NrrrBrrr)z::z::0z ::0.0.0.0)r rprevent_socket_inheritancerDrkr@rqrArrr IPPROTO_TCP TCP_NODELAYrr?rrrrar ) clsrrlr-r9r*rrrFrrrClistening_ipv6s rHr)zHTTPServer.prepare_socketsF }}VT51..t4r] d AI   % %di % H/  OOF--v/B/BA F :i#u> OOF..0B0BA F  "##D)D FJ ' 3&//) 322   ''););Q t #FLL1   s/EEEc(|j||S)z#Bind the socket to given interface.)rrFs rHr+zHTTPServer.bind_sockets  Yr'c|j}|jtjtjfvr |ddSt |t r t|}|S)z/Retrieve actual bind address from bound socket.Nr) getsocknamerlr rrrrrrFs rHr,z!HTTPServer.resolve_real_bind_addrs] '') >> NN OO   Ra= i 'YIr'c |jj|y#tj$r|j YywxYw)z#Process an incoming HTTPConnection.N)rrqueueFullrrs rH process_connzHTTPServer.process_conn*s5  MM  d #zz  JJL s#AAc|jS)zFlag interrupt of the server.)rrcs rHrzHTTPServer.interrupt2sr'c&|jtuS)z8Return whether the server is responding to an interrupt.)r_STOPPING_FOR_INTERRUPTrcs rHrz"HTTPServer._stopping_for_interrupt7s"999r'ct|_t|tr|j dt|t r|j d|j ||_y)aPerform the shutdown of this server and save the exception. Typically invoked by a worker thread in :py:mod:`~cheroot.workers.threadpool`, the exception is raised from the thread running :py:meth:`serve` once :py:meth:`stop` has completed. z!Keyboard Interrupt: shutting downz SystemExit raised: shutting downN)rUrrrSrPrTr)r@rs rHrzHTTPServer.interrupt<sJ2 i!2 3 NN> ? i , NN= > #r'c4|jsyd|_|j4|xjtj|jz z c_d|_|jj t |dd}|rt|jttfs |jdd\}}tj||tjtjD]X}|\}}}}} d} tj|||} | j!d| j#||f| j%Z t/|dr|j%d|_ |jj%|j0j |j2y#tj&$r| r| j%YwxYw#tj&$r*} | j(dt*j,vrYd} ~ d} ~ wwxYw)z5Gracefully shutdown a server that is serving forever.NFr rg?rr)rrrrrrr/rrrrrNr rrrrconnectrr rrr r?rshutdown_timeout) r@rFrrrsrr r9r _sarrs rHrzHTTPServer.stopPszz     ' NNtyy{T-=-== >N  tXt, dnnsEl;*!%!1!1!3BQ!7JD$ &11dF$4$4** *@C<HeZ  * & b(E BALL-IItTl3GGI*"tW% DK ! 4001 &||* ! *3||wwqz)G)GG Hs+&G>A F//%GGH- HH)rroNFFF)rFr)F);rQrRrSrTrrrrrr3rrrYr.rrrrrrrrr*rConnectionClassrrBrCrkeep_alive_conn_limitr`rrrrrsetterrr rr contextlibcontextmanagerrr-r rPrr staticmethodrD classmethodr)r+r,rRrrrrKr'rHrrsCJJGJFJK?H& GG$**;*?G.H EMMLGN$O9K!& J2A 37;@ !F)LVE 6  ( 9E'N%*   MM Qf222h *::$$&32r'rceZdZdZdZdZy)rzDBase class to interface HTTPServer with other systems, such as WSGI.c||_y)zuInitialize Gateway instance with request. Args: req (HTTPRequest): current HTTP request N)r[)r@r[s rHr`zGateway.__init__s r'ct)z>Process the current request. Must be overridden in a subclass.)rnrcs rHrzGateway.responds!!r'N)rQrRrSrTr`rrKr'rHrrsN"r'rz%cheroot.ssl.builtin.BuiltinSSLAdapterz&cheroot.ssl.pyopenssl.pyOpenSSLAdapter)builtin pyopensslct|j}t|trN|j d}||dzd}|d|} t j |}| t t||}|S|S#t$r"t|ttdg}Y;wxYw#t$rtd|d|dwxYw)z/Return an SSL adapter class for the given name.rrNr'z' object has no attribute ') ssl_adaptersrrrrfindr"modulesKeyError __import__globalslocalsr/ra)nameadapterlast_dot attr_namemod_pathmods rHrrs4::<(G'3==%HqLM* 9H% B++h'C{j  c9-G N7N BXwy&(RDAC B  Y(  sA8( B&8(B#"B#&C)rf)KrTrrre email.utilsr0r r"rrLr%rQplatformrPr_r urllib.parser functoolsrrrrr_compatrr workersr rGr r __all__systemrkrrIS_GAErrr ImportErrorrrr?rrrrqr4r7r6r:rrrASTERISKrrcompiler?rrXrUr=r-rrrrrr rrrrjrrKr'rHrs3AF   .., X__ ) + ? $b ) 4 45I J'5v:N '&*- 6> *  6= )v}% &2F          RZZ'<)@ AB$+w %GC(C(L,,^^BWWtDP /P /fBBJo 2o 2d " "&79 MA  !&Ss+F.. F?>F?