Dfj0dZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlmZddlmZmZmZddlmZddlmZddlmZdd lmZmZd Z e j!d kZ" ej#d d $dZ% e" oe% Z& e&r! ddl'Z'ddl(Z(n#e)$r  dZ&d\Z'Z(YnwxYwddl*Z*e"r2e+edr&e+edsde_,e+edsde_-e+eds erdnde_.dZ/dZ0dZ1dZ2dZ3dZ4dZ5d Z6d!Z7d"Z8ej9d:d#e8fZ;e<Z=gd$Z>e+e d%sie _?Gd&d'Z@Gd(d)e@ZAGd*d+ZBGd,d-ZCGd.d/ZDGd0d1ZEGd2d3ZFGd4d5ZGGd6d7ZHd8d9d:ZId=d<ZJdS)>a A high-speed, production ready, thread pooled, generic HTTP server. For those of you wanting to understand internals of this module, here's the basic call flow. The server's listening thread runs a very tight loop, sticking incoming connections onto a Queue:: server = HTTPServer(...) server.start() -> 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&eZdZdZddZdZdZdS)rz`Object for reading headers from an HTTP request. Interface and default implementation. Nc|i} |}|std|tkrn|tstd|ddtt fvr|}nh |td\}}n#t$rtdwxYw|}| |}|}| |s|tvr.| |}|rd ||f}|||<E|S)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. NTIllegal end of headers.HTTP requires CRLF terminatorsrzIllegal header line.s, )readline ValueErrorCRLFendswithSPACETABstripsplitCOLON_transform_key _allow_headercomma_separated_headersgetjoin)selfrfilehdictlinevkhnameexistings =/var/www/media/lib/python3.11/site-packages/cheroot/server.py__call__zHeaderReader.__call__sh =E# >>##D < !:;;;t||==&& C !ABBBBQBxE3<'' JJLL=::eQ//DAqq!===$%;<<<=GGII''**%%a(( +++ 99U++2 Ha=11AE%LG# J s B..CcdS)NTr@key_names rHr<zHeaderReader._allow_headerstr'cN|SN)r8titlerLs rHr;zHeaderReader._transform_keys~~%%'''r'rO)__name__ __module__ __qualname____doc__rIr<r;rKr'rHrrsQ 6666p(((((r'rc"eZdZdZfdZxZS)rzDCustom HeaderReader to exclude any headers with underscores in them.c`tt||}|od|vS)N_)superrr<)r@rMorig __class__s rHr<z(DropUnderscoreHeaderReader._allow_headers1/66DDXNN+8++r')rQrRrSrTr< __classcell__)rZs@rHrrs>NN,,,,,,,,,r'rcLeZdZdZdZdZd dZd dZd dZd Z d Z d Z e Z dS)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 c0||_||_d|_dS)z%Initialize SizeCheckWrapper instance.rN)rAmaxlen bytes_read)r@rAr^s rH__init__zSizeCheckWrapper.__init__s  r'c^|jr#|j|jkrtjdSdSrO)r^r_rMaxSizeExceededr@s rH _check_lengthzSizeCheckWrapper._check_length s9 ; +4?T[88(** * + +88r'Nc|j|}|xjt|z c_||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.readsDzt$$ 3t99$  r'c|M|j|}|xjt|z c_||Sg} |jd}|xjt|z c_|||t|dks|ddt krt|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 NT) rAr2r_rhrdappendLFEMPTYr?)r@rjrkress rHr2zSizeCheckWrapper.readlines  :&&t,,D OOs4yy (OO    K ':&&s++D OOs4yy (OO    JJt   4yy3$rss)r//zz#& 'r'rcd}g}||}|rO|||t|z }d|cxkr|krnnn||}|O|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.readlines9}}X&& + LL    SYY E8$$$$u$$$$$==**D  +  r'c8|jdSz*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_||SzGenerate next file chunk.)nextrAr_rhrdr@rks rH__next__zSizeCheckWrapper.__next__Vs>DJ 3t99$  r'rOr) rQrRrSrTr`rdrgr2r{rrrrrKr'rHrrs  +++    ''''6* DDDr'rcFeZdZdZdZd dZd dZd dZdZd Z d Z e Z dS) 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"||_||_dS)z%Initialize KnownLengthRFile instance.N)rA remaining)r@rAcontent_lengths rHr`zKnownLengthRFile.__init__gs 'r'Nc|jdkrdS||j}nt||j}|j|}|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.readlsc >Q  3 <>DDtT^,,Dzt$$ #d))# r'c|jdkrdS||j}nt||j}|j|}|xjt |zc_|S)rmrr')rrrAr2rhris rHr2zKnownLengthRFile.readlinese >Q  3 <>DDtT^,,Dz""4(( #d))# r'rcd}g}||}|rO|||t|z }d|cxkr|krnnn||}|O|Srurvrws rHr{zKnownLengthRFile.readlinesr|r'c8|jdSr~rrcs rHrzKnownLengthRFile.closerr'c|SrrKrcs rHrzKnownLengthRFile.__iter__rr'cht|j}|xjt|zc_|Sr)rrArrhrs rHrzKnownLengthRFile.__next__s,DJ #d))# r'rOr) rQrRrSrTr`rgr2r{rrrrrKr'rHrr`s ((( ((* DDDr'rcDeZdZdZd dZdZd dZd dZdd Zd Z d Z dS)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 cd||_||_d|_t|_||_d|_dS)z!Initialize ChunkedRFile instance.rFN)rAr^r_rrbufferbufsizeclosed)r@rAr^rs rHr`zChunkedRFile.__init__s0     r'c||jrdS|j}|xjt |z c_|jr*|j|jkrt jd|j| td} | d}t|d}n1#t$r$td|wxYw|dkr d|_dS|jr"|j|z|jkrtd|j|}|xjt |z c_|xj|z c_|jd}|t$kr"td t'|zd zdS) 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._fetchs ;  Fz""$$ 3t99$ ; 4?T[88(*DK zz||!!)Q// !JZ,,JJ   ;*--   ??DK F ; 64?Z7$+EE455 5  ++ 3u::% u zq!! 4<<d$&)*  z1HTTPRequest.read_request_line..s8L11!44r'rz HTTP/%s.%s)*rAr2rr4r5rr8r9r6 startswithrhtuplemaprr3 IndexErroruriuppermethodrrrurlsplit UnicodeErrorrr?rrportany FORWARD_SLASHQUOTED_SLASH_REGEXargs QUOTED_SLASHr authoritypathqsrprotocolrequest_protocolrr)r@ request_linerr req_protocolrpresprrrrfragmenturi_is_absolute_form uri_split_scheme _authority_path_qs _fragment_port invalid_pathdisallowed_absoluteatomsexsps rHrzHTTPRequest.read_request_linesVz**,,  $ 5 4    :..00L u$$T**   !#C   5 (4(:(:(<(<(B(B5!(L(L %FC**844 $$%'Muabb!''a00B2ww!||$$%'Lus3||$$BF{{$$46Nu  J'     !24L M M M55 llnn   $+ 5 5A   !2D 9 9 95 4:L4I4I#4N4N 1FItR     !24K L L L55 !' 3) ;* $ $ O(< D [J & &? $$%=>>>u --chhs|.D.DEEI9B 6GZYE !    c!999Y788   $$%8 u) )I%* *F *R(( )')( # C$$%Hu -}555-,,   >2 $$%6===u $$%7u|$$%2u /55d;;   $$%6 CCCuuuuu  $$U++D}-- ( 4'D    DK" %a( ) )3t{/CA/F+G+G G a5BqE>>  !A B B B5 ,!-B !;ts\AE(AE('>E(('FF#%H H-,H-;K KK=$O"" P,!PPc ||j|jn9#t$r,}|d|jdYd}~dSd}~wwxYw|jj} t|j dd}n'#t$r|ddYdSwxYw|r||kr|dddS|j d kr'|j d d d krd |_ n&|j d d dkrd |_ d}|j d kr;|j d}|rd| dD}d|_ |r1|D].}|dkrd |_ |dd |_ dS|j dd dkrd |jjdt"dt$t$f} |jj|n6#t,j$r$}|jdt0jvrYd}~nd}~wwxYwd S)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,cg|]<}||=SrK)r8lowerrs rHrz4HTTPRequest.read_request_headers..s7MMMA17799Maggiioo''MMMr',chunkedz501 Unimplementedr+s 100-continueasciis 100 Continue) header_readerrArr3rrrmax_request_body_sizerr>rrr9rr?rencoder6r4rwfilewritesocketerrorrsocket_errors_to_ignore)r@rmrbsclteencmsgs rHrz HTTPRequest.read_request_headerss    tz4> : : : :     !2BGAJ ? ? ?55555 {0 T^''(91==>>BB     !2   55    BII  .!    5  !Z / /~!!-55AA(,%~!!-55FF(,%  !Z / /##$899B NMM$MMM! ! ! !*$$(,D%%(()<===,0D) 55& >  i - - @ @(( $++G44e_dC  %%c****<   71:V%CCCDCCCC ts> # A!AA)(B B65B6H99I,I''I,c&|jj}|jr t|jj||_nnt |jdd}|r%||kr|j s| dddSt|jj||_|j | |jo||jr!|jjddSdS)z/Call the gateway and write its iterable output.rrrrNs0 )rr rrrrArrr>rrrgatewayrespondrensure_headers_sentrrr)r@rrs rHrzHTTPRequest.respond(s{0   ?%diot<>B r (((61 )$)/2>>DJ D!!))+++ 1t//11   0 IO ! !, / / / / / 0 0r'rct|}|jjd|d}dt|z}d}|d|d|dg}|dddvr*d |_|jd kr|d nd }|t|r?t|tr|d}|| |j j t|dS#tj$r%}|jd t$jvrYd}~dSd}~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 isinstancerrrrrr?rrrrr)r@rr proto_statusr content_typebufrs rHrzHTTPRequest.simple_response?sV&*k&:&:&:FFFC 1CHH<5    - -  ! !, / /    - -  "1": ' '$(D !%33 34444+ 4  #s## /jj.. JJsOOO  IO ! !%**S// 2 2 2 2 2|   wqz!???@????? s7D??E3E..E3cN|jsd|_|dSdS)z:Ensure headers are sent to the client if not already sent.TN)r send_headersrcs rHrzHTTPRequest.ensure_headers_sentds7  $D           r'cV|jr|rtt|ddd}|t|tg}|jjt |dS|jj|dS)z$Write unbuffered data to the client.rNr ) rhexrhrr4rrrrrr?)r@rchunk_size_hexr's rHrzHTTPRequest.writejs   )% ) U__QRR077@@N!45C IO ! !%**S// 2 2 2 2 2 IO ! !% ( ( ( ( (r'cd|jD}t|jdd}|dkrd|_nPd|vrL|dks|dvrnA|jd ko |jd k}|r"d|_|jd nd|_|js|jj }| |_d |vrN|jd kr"|jr|jd n!|js|jdd|jvrM|jdd |jj  df|js=|j s6t|jdd}|dkr|j|d|vrM|jdt"jd dfd|vr9|jd|jj df|jj d}|t,z|jzt.zg}|jD]5\}} ||t0zt,z| zt.z6|t.|jjt8|dS)zAssert, process, and send the HTTP response message-headers. You must set ``self.status``, and :py:attr:`self.outheaders ` before calling this. c<g|]\}}|SrK)r)rkeyvalues rHrz,HTTPRequest.send_headers..ys$???e???r'Nr iTscontent-length)i0rsHEAD)r,r s connection)r*r)r*rrztimeout={connection_timeout})connection_timeoutrrrsdatesDate)usegmtsserversServerr )rrrrrrrrprcan_add_keepalive_connectionrtimeoutrrgetattrrArgemailutils formatdate server_namerr6r4r:rrrrrr?) r@hkeysr needs_chunkedcan_keeprprotor'rErDs rHr)zHTTPRequest.send_headersss @?t???T[!_%% S==$(D ! ! e + +||v88*j8/ w.!1)-D&O**+MNNNN-1D)$ 1{?H(0LD !  % %%33(FO**+DEEE,KO**+IJJJ )T_ < < O " "/$+*=>>|$$ $   % +0A +  K;;I1}}  *** %   O " " &&d&33::<HH$    E ! ! O " " '..|<<$     $++G44u}t{*T12O 5 5DAq JJq5y5(1,t3 4 4 4 4 4 ejjoo.....r')FT)r)rQrRrSrTrrrrrrrrr r`rrrrrrrr)rKr'rHr r |s F@ DDI$J; E@M<!LNNM''''B   DaaaF^^^@000.####J   )))Y/Y/Y/Y/Y/r'r ceZdZdZdZdZdZejZ ejZ e Z dZ dZdZefdZdZdZdZdZdZd Zed Zed Zed Zd ZedZedZdZdS)rz#An HTTP connection (active socket).NFc\||_||_||d|j|_||d|j|_d|_|jj|_|jj|_td|j |_ td|j |_ dS)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) rrrbufsizerAwbufsizer requests_seenpeercreds_enabledpeercreds_resolve_enabledrresolve_peer_credsget_peer_creds)r@rsockmakefiles rHr`zHTTPConnection.__init__s  XdD$-88 XdD$-88 !%!>)-)N& !Ia !8 9 9  !Ia !4 5 5 r'cd} ||j|}||jjdr|xjdz c_|jsdSd}||jsdSnN#tj $r}|j d}d}||vr"|r |r|j r| |dn[|tjvrM|jdt!|zt"jd | |d Yd }~nd }~wt&t(f$rtj$rYntj$r||Yn`t0$rT}|jt!|t"jd | |d Yd }~nd }~wwxYwdS) 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)RequestHandlerClassrrstatsrHrrrrrrr_conditional_errorrr error_logrloggingWARNINGKeyboardInterrupt SystemExit FatalSSLAlert NoSSLError_handle_no_ssl ExceptionERROR)r@ request_seenreqrerrnum timeout_errss rH communicatezHTTPConnection.communicatesE  * F**4;==C      { + (""a'""9 uL KKMMM' t | J J JWQZFFL%% %H#H#2EH++C1FGGGv=== %%%V 4!/T&''-HIII!:.    #    D  % % %    $ $ $ $ $ F F F K ! !R  "     # #C)D E E E E E E E E  F us8AA?A??G BD###G #G - G 6A GG c|r|jrdS |jj}n#t$r|jj}YnwxYwt |d|j|_d}|d|d|_ dS)NrDzUThe client sent a plain HTTP request, but this server only speaks HTTPS on this port.rT) rr_sockAttributeError_socketr rGrrlinger)r@rb resp_sockrs rHr^zHTTPConnection._handle_no_ssl.s c&  F , )II , , , +III ,")T4=AA  :  -s333 s 33c|r|jrdS ||dS#tj$rYdStj$r||YdSwxYw)zvRespond with an error. Don't bother writing if a response has already started being written. N)rrrr\r]r^)r@rbresponses rHrVz!HTTPConnection._conditional_error?s  c&  F %    ) ) ) ) )#    DD  % % %    $ $ $ $ $ $ %s$A#AAc|j|js/||jdSdS)z,Close the socket underlying this connection.N)rArrj_close_kernel_socketrrcs rHrzHTTPConnection.closeOsU {   % % ' ' ' K        Dr'cd}ts|jjtjkrt d|jst d |jtjtj tj |}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_WINDOWSrfamilyAF_UNIXNotImplementedErrorrI RuntimeError getsockopt SOL_SOCKETrstructcalcsizeunpackr)r@PEERCRED_STRUCT_DEF peer_credspiduidgid socket_errs rHrLzHTTPConnection.get_peer_credsbs#  +v~==%G ' B  !//!6#5 344 J #M*=zJJMCcS= | / / / J . /s AB**C9 CCc6|\}}}|S)z,Return the id of the connected peer process.rL)r@r~rWs rHpeer_pidzHTTPConnection.peer_pids '')) Q r'c6|\}}}|S)z1Return the user id of the connected peer process.r)r@rWrs rHpeer_uidzHTTPConnection.peer_uids '')) 3 r'c6|\}}}|S)z2Return the group id of the connected peer process.r)r@rWrs rHpeer_gidzHTTPConnection.peer_gids '')) 1c r'ctstd|jstdt j|jj}tj |j j }||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_RESOLVABLErurJrvpwdgetpwuidrpw_namegrpgetgrgidrgr_name)r@usergroups rHrKz!HTTPConnection.resolve_peer_credssy% %6  / ? |DM**2 T]++3U{r'c4|\}}|S)z2Return the username of the connected peer process.rK)r@rrWs rH peer_userzHTTPConnection.peer_users))++a r'c4|\}}|S)z/Return the group of the connected peer process.r)r@rWrs rH peer_groupzHTTPConnection.peer_groups**,,5 r'ct|jd|jj} |tjdS#tj$rYdStj$r}|jtjvrYd}~dSd}~wwxYw)z0Terminate the connection at the transport level. sock_shutdownN) r8rshutdown SHUT_RDWRr#acceptable_sock_shutdown_exceptionsrerrno$acceptable_sock_shutdown_error_codes)r@res rHroz#HTTPConnection._close_kernel_sockets K K      HV% & & & & &9    DD|   wfIIIJIIIII s9A8 A8A33A8) rQrRrSrT remote_addr remote_portssl_envioDEFAULT_BUFFER_SIZErFrGr rTrIrJ last_usedr r`rerjr^rVrrLpropertyrrrrKrrrorKr'rHrrsb--KKG%H%H% %I.6    6111fF"%%% &)!)!)!VX X X 0X X r'rc4eZdZdZdZdZdZ dZ dZ dZ dZ dZ dZ dZ dZ de Z dZ d Z d Z d Z d Z eZ dZ d Z d Z d Z dZ d)dZdZdZ dZ!e"dZ#e#j$dZ#dZ%dZ&dZ'dZ(e)j*dZ+e"dZ,dZ-d*dZ.d+dZ/dZ0e1d Z2e3 d,d!Z4e1d"Z5e1d#Z6d$Z7e"d%Z8e"d&Z9e8j$d'Z8d(Z:dS)-rzAn HTTP server.z 127.0.0.1Nrr g?zCheroot/{version!s})versionFrTroc ||_||_tj||pd||_|s|j}||_||_|o||_||_ | dS)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 ThreadPoolrequestsrr<rIrJ reuse_port clear_stats) r@rr minthreads maxthreadsr<rIrJrs rHr`zHTTPServer.__init__3s$# "- joA:     ',K&!2 % ;*; &% r'c d_d_idddfddfdd dd fd d fd dfddfddddddddddddddddi_jtjd t z<dS)!zReset server stat counters..NrrPFz Bind Addressc,tjSrO)rrsr@s rHz(HTTPServer.clear_stats..\sd4>&:&:r'zRun timecB|d rdpS)NrProruntimers rHrz(HTTPServer.clear_stats..]s q|#3";"Mt||~~r'Acceptsz Accepts/secc>|dz S)Nrrrs rHrz(HTTPServer.clear_stats.._sQy\DLLNN%Br'Queuec0tjddS)Nqsizer8rrs rHrz(HTTPServer.clear_stats..`swt}gtDDr'ThreadscJttjdgS)N_threads)rhr8rrs rHrz(HTTPServer.clear_stats..asWT]J%K%K!L!Lr'z Threads Idlec0tjddS)Nidlerrs rHrz(HTTPServer.clear_stats..bsgdmVT&J&Jr'z Socket ErrorsRequestsc||d rdp1td|dDdS)NrProc38K|]}|d|VdS)rNrKrws rH z;HTTPServer.clear_stats....es0HHa:q!!HHHHHHr'Worker Threadsrsumvaluesrs rHrz(HTTPServer.clear_stats..dsJq|#3";#sHH1-=+>+E+E+G+GHHH!@@r' Bytes Readc||d rdp1td|dDdS)NrProc38K|]}|d|VdS)rNrKrs rHrz;HTTPServer.clear_stats....hs0JJ<##JJJJJJr'rrrrs rHrz(HTTPServer.clear_stats..gsJ9%5$=2%JJQ/?-@-G-G-I-IJJJABBr' Bytes Writtenc||d rdp1td|dDdS)NrProc38K|]}|d|VdS)rNrKrs rHrz;HTTPServer.clear_stats....ks2MM1#?#A&&MMMMMMr'rrrrs rHrz(HTTPServer.clear_stats..jsKAiL(8'@b(CMM2B0C0J0J0L0LMMMEEr' Work Timec||d rdp1td|dDdS)NrProc38K|]}|d|VdS)rNrKrs rHrz;HTTPServer.clear_stats....os0IIq;""IIIIIIr'rrrrs rHrz(HTTPServer.clear_stats..nsJ) $4#<"$IIA.>,?,F,F,H,HIII1AAr'zRead Throughputc||d rdp1td|dDdS)NrProc3`K|])}|d||d|pdz V*dS)rrư>NrKrs rHrz;HTTPServer.clear_stats....rs\$AlOA&&.!K.*;*;*CtDr'rrrrs rHrz(HTTPServer.clear_stats..qsXa l*:)B*c/07799 GGr'zWrite Throughputc||d rdp1td|dDdS)NrProc3`K|])}|d||d|pdz V*dS)rrrNrKrs rHrz;HTTPServer.clear_stats....xs]'Ao&q))^Q{^A->->-F$Gr'rrrrs rHrz(HTTPServer.clear_stats..wsXq|+;*C+s/07799 HHr'rzCheroot HTTPServer %d) _start_time _run_timerUrXr-idrcs`rHrzHTTPServer.clear_statsVsk$ u$ ::::$  MMMM$  q $ BBBB $ DDDD $  LLLL$  JJJJ$  Q$  $  $ !$ ( )$ .   /$ : !!;$ F bG$  JBF2RXX=>>>r'cd|j|jS|jtj|jz zS)zReturn server uptime.)rrtimercs rHrzHTTPServer.runtimes.   #> !>TY[[43C%CD Dr'c@|jd|jjd|jdS)z1Render Server instance representing bind address..(r)rRrZrQrrcs rH__str__zHTTPServer.__str__s- OOOT^444 NNN  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_addrs 4r'cpt|tr|ddvrtd||_dS)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)r$rr3r)r@r0s rHrzHTTPServer.bind_addrsJ eU # # aJ(>(>6   r'c |dS#t$r}|j}|s||_||d}~wt$r}|j}|s||_||d}~wwxYw)z4Run the server forever, and stop it cleanly on exit.N)startrZ interruptr[)r@ kb_intr_excunderlying_interrupt sys_exit_excs rH safe_startzHTTPServer.safe_starts 9 JJLLLLL  8 8 8#'> ' -!,#7 7 9 9 9#'> ' .!-$8 8  9s A5 AAAc(d|_|jd|jz|_d|_d}t jddr1tjdtjtj|_nt|j ttfrY | |j nB#tj$r*}|d|j d|d}tj||d}~wwxYw|j \}} tj||tjtjd tj}nO#tj$r=tj}|j }d |vrtj}|d z}|tjd d |fg}YnwxYw|D]q}|\} } } } } || | | nN#tj$r<}|d| d|d}|jr|jd|_Yd}~jd}~wwxYw|jstj||jd |j|jt3j||_|jd|_t?j|_ dS)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_PIDr z -- (z: rr:)rrrrT)! _interruptsoftwarerrosgetenvfromfdAF_INET SOCK_STREAMr$rr#bytesbind_unix_socketr getaddrinfo AF_UNSPEC AI_PASSIVEgaierrorrbindr settimeoutlistenrequest_queue_sizerConnectionManager _connectionsrrrrr)r@rserrhostrinfo sock_typerrsafsocktyper@ _canonnamesas rHpreparezHTTPServer.prepares  = '$,6DM * 9\4 ( (' ' -6>6;MNNDKK e 5 5$ ' 2%%dn5555< 2 2 2*-##t~~~tttDl3''T1 2JD$ K)$ 0&6+<? K K K"N  N $;; &I )F 2I"F$62yIJ K ' '693HeZ'IIb(E222E|'''.1cc222ttt????%z2      /w}"  j   > %.  3. ~ %n$  % % % %s0=A0/A0cV||dS)zmRun the server forever. It is shortcut for invoking :func:`prepare()` then :func:`serve()`. N)rrrcs rHrzHTTPServer.start+s"  r'c#K|tj|j}d|_| |V|dS#|wxYw)z4Context manager for running this server in a thread.)targetTN)r threadingThreadrdaemonrstop)r@threads rH_run_in_threadzHTTPServer._run_in_thread7so !444   LLL IIKKKKKDIIKKKKs A''A=c(|jo |jjS)z>Flag whether it is allowed to add a new keep-alive connection.)rrr6rcs rHr6z'HTTPServer.can_add_keepalive_connectionCszLd/LLr'ct|jr|j|dS|dS)z7Put an idle connection back into the ConnectionManager.N)rrputrr@rs rHput_connzHTTPServer.put_connHs< :    ! !$ ' ' ' ' ' JJLLLLLr'rcPtjd|tj|rRt j}tj|tjdSdS)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)sysstderrrrflush traceback_ format_exc)r@rrRrStbliness rHrWzHTTPServer.error_logPs +++44555    +--G J  W % % % J         r'c ||j||||j|j|j}|||jx}|_|||_|S)z.Create (or recreate) the actual socket object.)prepare_socketrnodelayrr bind_socketrresolve_real_bind_addr)r@rstyper@rMs rHrzHTTPServer.bind`sl"" N D% L$* O    "--dDNCCCt{44T:: r'c tr tdd} tj|jnd#t $rYnXt $r}t|}d|vrYd}~n6d}~wt$r&}t|}d|vr d|vrd|vrYd}~nd}~wwxYw||tj tj d|j |j |j } tj||d }n#t $rd }YnwxYw |||}n(#tj$r|wxYw||} |s@ tj||n'#t,$rtj||d YnwxYwd }n#t $rYnwxYw|s!|d t2j||_||_ |S)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)rrsr2r@r/rrTF)follow_symlinksz(Failed to set socket fs mode permissions)rR)rrr3runlinkrOSError TypeErrorr#r.rrtrr/rrfchmodfilenor0rrr1lchmodrhchmodrWrXrY)r@rfs_permissionstyp_errerr_msgval_errrM FS_PERMS_SETs rHrzHTTPServer.bind_unix_socketls   B   Idn % % % %        'llG="## #####    'llG(/677,G;;4;BCC "">(:!Ld.> #   ! B Idkkmm^ 4 4 4LL ! ! ! LLL ! ##D)44DD|    JJLLL  //55   C $OIi8888%OOOHYNNNNNNO#     D   NN:o     #  s{5 B B A## B0BB*D DDD..%E,F00FF0!F*'F0)F**F00 F=<F=c4|dd\}}|dk}|jtjtjfvrt d|rt dt tdr-|tjtjddSt tdr-|tjtj ddStr-|tjtj ddStd) NrrzCannot reuse a non-IP socketz"Cannot reuse an ephemeral port (0)SO_REUSEPORT_LBr SO_REUSEPORTz,Current platform does not support port reuse) rsrrrr3hasattr setsockoptrxrBrCrr SO_REUSEADDRru)socket_rr rIS_EPHEMERAL_PORTs rH_make_socket_reusablez HTTPServer._make_socket_reusables rr] d AI >&.&/!B B B;<< <  CABB B 6, - -    v0&2H! L L L L L V^ , ,    v0&2Eq I I I I I     v0&2Eq I I I I I%> r'ctj|||}tj||dd\} } | dk} |r|||ts.| s, |tjtjd|rGt|ttfs+|tj tj d|| |}ttdo|tjko| dv} | rI |tjtjdn#t$tjf$rYnwxYw|S)z%Create and prepare the socket object.NrrrGrrr)z::z::0z ::0.0.0.0)rrprevent_socket_inheritancerIrrrErxrFr$r#r IPPROTO_TCP TCP_NODELAYrrDrrrrhr) clsrrsr2r@r/rrrMr rrHlistening_ipv6s rHr.zHTTPServer.prepare_sockets }VT511.t444rr] d AI  I  % %di % H H H G/ G  OOF-v/BA F F F  G:i#u>> G OOF.0BA F F F  "##D))D FJ ' ' 3&/) 322    ');Q#FL1      s+EEEc0|||S)z#Bind the socket to given interface.)rrKs rHr0zHTTPServer.bind_sockets  Yr'c|}|jtjtjfvr |ddSt |t rt|}|S)z/Retrieve actual bind address from bound socket.Nr) getsocknamersrrrr$rrrKs rHr1z!HTTPServer.resolve_real_bind_addrsk '')) > N O    RaR= i ' ' (YIr'c |j|dS#tj$r|YdSwxYw)z#Process an incoming HTTPConnection.N)rr"queueFullrr#s rH process_connzHTTPServer.process_conn*sS  M  d # # # # #z    JJLLLLLL s#AAc|jS)zFlag interrupt of the server.)rrcs rHrzHTTPServer.interrupt2s r'c|jtuS)z8Return whether the server is responding to an interrupt.)r_STOPPING_FOR_INTERRUPTrcs rHrz"HTTPServer._stopping_for_interrupt7s"999r'ct|_t|tr|dt|t r|d|||_dS)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)rZrr$rZrWr[r)r@rs rHrzHTTPServer.interrupt<so2 i!2 3 3 @ NN> ? ? ? i , , ? NN= > > > #r'c|jsdSd|_|j)|xjtj|jz z c_d|_|jt |dd}|r^t|jttfs | dd\}}tj ||tjtjD]}|\}}}}} d} tj |||} | d| ||f| d#tj$r| r| YwxYwn6#tj$r$} | jdt*jvrYd} ~ nd} ~ wwxYwt/|dr|d|_ |j|j|jdS)z5Gracefully shutdown a server that is serving forever.NFrrg?rr)rrrrrrr8r$rr#rrSrrrrrconnectrrrrrrDrshutdown_timeout) r@rMr rrsr r r@r_sarrs rHrzHTTPServer.stopPs+z  F   ' NNty{{T-== >NN    tXt,, # dnsEl;; **!%!1!1!3!3BQB!7JD$ &1dF$4*  **@C<HeZ  * & b(E B BALL---IItTl333GGIIII%|*** * ! **|wqz)GGG HGGGG8tW%%  DK !!! 4011111s+E2/AE%E.-E.2F%F  F%)rroNFFF)rr%Fr)F);rQrRrSrTrrrrrr<rrr^r7rrrrrrrr r/rConnectionClassrrIrJrkeep_alive_conn_limitr`rrrrrsetterrrrr contextlibcontextmanagerrr6r$rWrr staticmethodrI classmethodr.r0r1rWrrrrKr'rHrrsKJJGJFJK?H& GG$**;*??G.H EMMLGN$O9K!& J2A 37;@ !!!!F)L)L)LVEEE   X6   ( 9 9 9E'E'E'N%%%*      MMXM    QQQf\2222[2h\ \*X::X:$$$&3232323232r'rceZdZdZdZdZdS)rzDBase class to interface HTTPServer with other systems, such as WSGI.c||_dS)zuInitialize Gateway instance with request. Args: req (HTTPRequest): current HTTP request N)rb)r@rbs rHr`zGateway.__init__s r'ct)z>Process the current request. Must be overridden in a subclass.)rurcs rHrzGateway.responds!!r'N)rQrRrSrTr`rrKr'rHrrs8NN"""""r'rz%cheroot.ssl.builtin.BuiltinSSLAdapterz&cheroot.ssl.pyopenssl.pyOpenSSLAdapter)builtin pyopensslrjct|}t|tr|d}||dzd}|d|} t j|}|tn;#t$r.t|ttdg}YnwxYw t||}n$#t$rtd|d|dwxYw|S)z/Return an SSL adapter class for the given name.rrNr'z' object has no attribute ') ssl_adaptersrr$r#rfindr'modulesKeyError __import__globalslocalsr8rh)nameadapterlast_dot attr_namemod_pathmods rHrrs4::<<(G'3==%%HqLMM* 9H9% B+h'C{jj  B B BXwyy&((RDAACCC B  c9--GG    .88YYY(   Ns""B5B=<B=C!C3)rj)KrTrrre email.utilsr9rr'rrSr*rXplatformrUrcr urllib.parser functoolsrrrrr_compatrr workersr rNr r __all__systemrrrrIS_GAErrr ImportErrorryrDrrrrqr4r7r6r:rrrASTERISKrrcompiler?rr_rZr=r-rrrrrr rrrrnrrKr'rHrsAAF   ..........,,,,,,,, X_  ) + ? $b ) ) 4 45I J J'5v:N     !&SSSMMM ''&*-- 76> * *!  76= ) ) wv}%%. &-2F          RZ'<)@ A ABB$)++ww %%GC(C(C(C(C(C(C(C(L,,,,,,,,^^^^^^^^BWWWWWWWWtDP /P /P /P /P /P /P /P /fBBBBBBBBJo 2o 2o 2o 2o 2o 2o 2o 2d " " " " " " " "&79 s*B33 CC