qiL9SrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKrSSKrSSKJr SSKJrJrJr SSKJrJr SSKJrJr SSKJr S r \RB"5S :Hr"\RF"S S 5RIS 5r%\"(+=(a \%(+r&\&(aSSK'r'SSK(r(SSK*r*OSur'r(r*\"(a8\+"\ S5(a*\+"\ S5(dS\ l,\+"\ S5(dS\ l-\+"\ S5(d\(aSOS\ l.Sr/Sr0Sr1Sr2Sr3Sr4Sr5S r6S!r7S"r8\ Rr"SRuS#\8455r;\<"5r=/S$Qr>\+"\S%5(d0\l?"S&S'5r@"S(S)\@5rA"S*S+5rB"S,S-5rC"S.S/5rD"S0S15rE"S2S35rF"S4S55rG"S6S75rHS8S9S:.rIS 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) __version__ connectionserrors)IS_PPCbton)MakeFile StreamWriter) threadpool) ChunkedRFileDropUnderscoreHeaderReaderGatewayHTTPConnection HTTPRequest HTTPServer HeaderReaderKnownLengthRFileSizeCheckWrapperget_ssl_adapter_classWindowsSERVER_SOFTWAREzGoogle App Engine/F)NN)NNNAF_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.\rSrSrSrSSjrSrSrSrg) rzXObject for reading headers from an HTTP request. Interface and default implementation. NcRUc0nSnUR5nU(d [S5eU[:XaU$UR[5(d [S5eUSS[[ 1;aUR 5nO<UR[S5upeUR 5nURU5nUnURW5(dMU[;a*URU5nU(aSRXu45nXRU'GM![a [S5ef=f)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)selfrfilehdicthnamelinevkexistings C/home/kali/flask_env/lib/python3.13/site-packages/cheroot/server.py__call__HeaderReader.__call__s =E>>#D !:;;t|: 9==&& !ABBBQxE3<' JJL=::eQ/DAGGI''*%%a((++ 99U+ H=1A%LG,"=$%;<<=s DD&cg)NTrAkey_names rIr=HeaderReader._allow_headersr'c>UR5R5$N)r9titlerNs rIr<HeaderReader._transform_key s~~%%''r'rMrR) __name__ __module__ __qualname____firstlineno____doc__rJr=r<__static_attributes__rMr'rIrrs 7r(r'rc,^\rSrSrSrU4SjrSrU=r$)rizDCustom HeaderReader to exclude any headers with underscores in them.cF>[[U] U5nU=(a SU;$)N_)superrr=)rArOorig __class__s rIr=(DropUnderscoreHeaderReader._allow_headers%/DXN+8++r'rM)rUrVrWrXrYr=rZ __classcell__)r`s@rIrrsN,,r'rcX\rSrSrSrSrSrS SjrS SjrSSjr S r S r S r \ r S rg)rizWraps 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*XlX lSUlg)z%Initialize SizeCheckWrapper instance.rN)rBmaxlen bytes_read)rArBres rI__init__SizeCheckWrapper.__init__s  r'c|UR(a+URUR:a[ReggrR)rerfrMaxSizeExceededrAs rI _check_lengthSizeCheckWrapper._check_length$s+ ;;4??T[[8(( (9;r'NcURRU5nU=R[U5- slUR 5 U$)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 )rBreadrflenrlrAsizedatas rIrpSizeCheckWrapper.read(s9zzt$ 3t9$  r'cUbKURRU5nU=R[U5- slUR 5 U$/nURRS5nU=R[U5- slUR 5 UR U5 [U5S:d USS[ :Xa[RU5$M)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) rBr3rfrqrlappendLFEMPTYr@)rArsrtress rIr3SizeCheckWrapper.readline6s  ::&&t,D OOs4y (O    K::&&s+D OOs4y (O    JJt 4y3$rs)r/zz#&r'cSn/nURU5nU(aKURU5 U[U5- nSUs=:a U::aU$ URU5nU(aMKU$zRead 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] rr3rzrqrAsizehinttotallinesrEs rI readlinesSizeCheckWrapper.readlinesQo}}X& LL  SY E8$u$ %==*D d  r'c8URR5 gz*Release resources allocated for ``rfile``.NrBcloserks rIrSizeCheckWrapper.closef r'cU$zReturn file iterator.rMrks rI__iter__SizeCheckWrapper.__iter__j r'c[UR5nU=R[U5- slUR 5 U$zGenerate next file chunk.)nextrBrfrqrlrArts rI__next__SizeCheckWrapper.__next__ns3DJJ 3t9$  r')rfrerBrRr)rUrVrWrXrYrgrlrpr3rrrrrrZrMr'rIrrs6  ) '6* Dr'rcR\rSrSrSrSrS SjrS SjrS SjrSr S r S r \ r S r g)rixzWraps 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 cXlX lg)z%Initialize KnownLengthRFile instance.N)rB remaining)rArBcontent_lengths rIrgKnownLengthRFile.__init__s  'r'NcURS:XagUc URnO[XR5nURRU5nU=R[ U5-slU$)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')rminrBrprqrrs rIrpKnownLengthRFile.readsX >>Q  <>>Dt^^,Dzzt$ #d)# r'cURS:XagUc URnO[XR5nURRU5nU=R[ U5-slU$)rwrr')rrrBr3rqrrs rIr3KnownLengthRFile.readlinesZ >>Q  <>>Dt^^,Dzz""4( #d)# r'cSn/nURU5nU(aKURU5 U[U5- nSUs=:a U::aU$ URU5nU(aMKU$rrrs rIrKnownLengthRFile.readlinesrr'c8URR5 grrrks rIrKnownLengthRFile.closerr'cU$rrMrks rIrKnownLengthRFile.__iter__rr'cl[UR5nU=R[U5-slU$r)rrBrrqrs rIrKnownLengthRFile.__next__s'DJJ #d)# r')rrBrRr)rUrVrWrXrYrgrpr3rrrrrrZrMr'rIrrxs1 ( ((* Dr'rcR\rSrSrSrS SjrSrS SjrS SjrSSjr S r S r S r g)r iaWraps 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 cZXlX lSUl[UlX0lSUlg)z!Initialize ChunkedRFile instance.rFN)rBrerfr|bufferbufsizeclosed)rArBrers rIrgChunkedRFile.__init__s&     r'cUR(agURR5nU=R[ U5- slUR (a;URUR :a![ R"SUR 5eUR5R[S5nURS5n[US5nUS::aSUlgUR (a(URU-UR :a [S5eURRU5nU=R[ U5- slU=R U- slURRS5nU[":wa[S[%U5-S -5eg![a [SW<35ef=f) NRequest Entity Too LargerrzBad chunked transfer size: Tz2Bad chunked transfer coding (expected '\r\n', got ))rrBr3rfrqrerrjr9r: SEMICOLONpopintr4IOErrorrprr5repr)rArE chunk_sizechunkcrlfs rI_fetchChunkedRFile._fetchsu ;; zz""$ 3t9$ ;;4??T[[8((*   zz|!!)Q/ !JZ,J ?DK  ;;4??Z7$++E45 5  + 3u:% u zzq! 4<d$&)*  ' -j^<  s <F..GNcd[nUS:XaU$U(a[U5U:aU$UR(d#UR5 UR(dU$U(a4U[U5- nX RSU- nURUSUlOX R- n[UlM)rorN)r|rqrr)rArsrtrs rIrpChunkedRFile.reads 19KD T) ;; {{K 3t9,  JY//"kk)*5  ## !r'c[nUS:XaU$U(a[U5U:aU$UR(d#UR5 UR(dU$URR [ 5nU(axUS:Xa4U[U5- nX RSU- nURUSUlO[ U[U5- U5nX RSU- nURUSUlOEUS:XaX R- n[UlO%X RSU- nURUSUlGM2)rwrryN)r|rqrrfindr{r)rArsrt newline_posrs rIr3ChunkedRFile.readline2s 19KD T) ;; {{K++**2.K"$ $s4y 0IKK 33D"&++ij"9DK #D3t9$4k BIKK 33D"&++ij"9DK" ##  L[11"kk+,7 3r'cSn/nURU5nU(aKURU5 U[U5- nSUs=:a U::aU$ URU5nU(aMKU$rrrs rIrChunkedRFile.readlines[rr'c## UR(d [S5eURR5nU(d [S5eU=R[ U5- slUR (a%URUR :a [S5eU[:XagUR[5(d [S5eUv M7f)zPRead HTTP headers and yield them. :yields: CRLF separated lines :ytype: bytes z:Cannot read trailers until the request body has been read.r1rr2N) rr4rBr3rfrqrerr5r6)rArEs rIread_trailer_linesChunkedRFile.read_trailer_linesps{{L ::&&(D !:;; OOs4y (O{{t<899t|==&& !ABBJ!sCCc8URR5 grrrks rIrChunkedRFile.closerr')rrrfrrerB)i rRr) rUrVrWrXrYrgrrpr3rrrrZrMr'rIr r s- )V$@'8R*<r'r c\rSrSrSrSrSr0r/rSr Sr Sr \ "5r SSjrSrSrSrS rSS jrS rS rS rSrg)rizjAn HTTP Request (and response). A single HTTP connection may consist of multiple request/response pairs. NFcZXlX lSUlSUlSUlURR bSUlSUl0UlSUl/Ul SUl URRUl SUl URRUlX0lX@lg)aInitialize HTTP request container instance. Args: server (HTTPServer): web server object receiving this request conn (HTTPConnection): HTTP connection object for this request proxy_mode (bool): whether this HTTPServer should behave as a PROXY server for certain requests strict_mode (bool): whether we should return a 400 Bad Request when we encounter a request that a HTTP compliant client should not be making FshttpNshttpszHTTP/1.0r)serverconnreadystarted_requestscheme ssl_adapterresponse_protocol inheadersstatus outheaders sent_headersr`close_connection chunked_read chunked_write proxy_mode strict_mode)rArrrrs rIrgHTTPRequest.__init__s   $ ;; " " ."DK!+ ! $ ? ?!!^^99$&r'c[URRURR5UlUR 5nU(dgUR5nU(dgSUl g![ Ra URSS5 gf=f![ Ra URSS5 gf=f)z;Parse the next HTTP request start-line and message-headers.Nz414 Request-URI Too LongzHThe Request-URI sent with the request exceeds the maximum allowed bytes.413 Request Entity Too LargezCThe headers sent with the request exceed the maximum allowed bytes.T) rrrBrmax_request_header_sizeread_request_linerrjsimple_responseread_request_headersr)rAsuccesss rI parse_requestHTTPRequest.parse_requests% IIOO KK / /   ,,.G //1G 1%%   *!    %%   .!    s#A6B"6&BB"&C  C c URR5nSUlU(dgU[:Xa"URR5nU(dgUR [5(dUR SS5 gUR 5R[S5up#nURS5(dUR SS5 gUSS RS S 5n[U5S:waUR SS 5 g[[[U55nUS :aUR SS5 gX0lUR#5UlUR&(a$X R$:waSnUR SU5 g[(R*R-U5upxpn U=(d Un UR$S:XaUR0(a U (aUOU n GOUR$S:XaUR0(dUR S5 g[(R*R-SR3SU455n U upnnn[4n[6R8"[5 U R:nS S S 5 X:g=(d U(+=(d [=UUUU45nU(aUR SS5 gU=p[4=n=pGO(UR&=(a UR0(+=(a U nU(aUR SS5 gUR&=(a( UR[>5(+=(a U (+nU(aSnUR SU5 gU (aUR SS5 gU cUR SS5 g[@RU 5Vs/sH"n[(R*RCU5PM$ nn[FR3U5n U R[>5(d [>U -n U[4LaXpl$Xl%Xl&Xl'[URPRRS5[URPRRS54nUSUS:waUR S5 gX@l*S[WUU5-Ul,g![[4a UR SS5 gf=f![.a UR SS5 gf=f!,(df  GN=fs snf![a)nUR SURDS5 S nAgS nAff=f) zRead and parse first line of the HTTP request. Returns: bool: True if the request line is valid or False if it's malformed. TF400 Bad Requestr2rsHTTP/z$Malformed Request-Line: bad protocolN.rz#Malformed Request-Line: bad version)rrz505 HTTP Version Not SupportedzCannot fulfill requestzMalformed Request-LinezMalformed method name: According to RFC 2616 (section 5.1.1) and its successors RFC 7230 (section 3.1.1) and RFC 7231 (section 4.1) method names are case-sensitive and uppercase.zMalformed Request-URIsOPTIONSsCONNECTz405 Method Not Allowedr's//zFInvalid path in Request-URI: request-target must match authority-form.z2Absolute URI not allowed if server is not a proxy.zInvalid path in Request-URI: request-target must contain origin-form which starts with absolute-path (URI starting with a slash "/").z!Illegal #fragment in Request-URI.zInvalid path in Request-URI.rz HTTP/%s.%s)-rBr3rr5r6rr9r:r7 startswithrqtuplemaprr4 IndexErroruriuppermethodrurllibparseurlsplit UnicodeErrorrr@r| contextlibsuppressportany FORWARD_SLASHQUOTED_SLASH_REGEXunquote_to_bytesargs QUOTED_SLASHr authoritypathqsrprotocolrequest_protocolrr)rA request_linerr req_protocolrpresprrrrfragmenturi_is_absolute_form uri_split_scheme _authority_path_qs _fragment_port invalid_pathdisallowed_absolutexatomsexsps rIrHTTPRequest.read_request_lineszz**,  $ 4   ::..0L$$T**  !0  (4(:(:(<(B(B5!(L %F**844$$%:ab!''a0B2w!|$$%9s3|$BF{$$4, lln   ++ 5A   !2D 9 4:LL4I4I#4N 1Ft &2 ;;* $ OO(<  [[J &??$$%=> --chhs|.DEI9B 6GYE$$Z0!1!999Y78  $$%8 ) )I%* *F *R(  )')( #C$$%H  -}55-,,  >2 $$%6=$$%7|$$%2  055d;;LL11!4; $$U+D}-- 4'D   K" %%a( )3t{{/C/CA/F+G G a5BqE>  !A B ,!-B !;OJ'   !24L M &   !24K L 210b $$%6 C sgAS6S 1S#S+5 T +T$)T+T$"S('S(+T  T  TT$$ U.UUcURURUR5 UR Rn[URRSS55nU(aX2:aUR SS5 gURS :Xa(URRS S 5S :XaS Ul O'URRS S 5S:waS Ul SnURS :XauURRS5nU(aSURS5Vs/sH7oUR5(dMUR5R5PM9 nnSUlU(a0UH*nUS:Xa S UlMUR S5 S Ul g URRSS 5S:XalS R!UR R"R%S5[&S[([(45nUR*R,R/U5 g g ![a)nUR SUR S5 SnAgSnAff=f![a UR SS5 gf=fs snf![0R2a,nUR S[4R6;aeSnAg SnAff=f)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_readerrBrr4rrrmax_request_body_sizerr?rrr:r9lowerrr@rencoder7r5rwfilewritesocketerrorrsocket_errors_to_ignore)rArmrbsclterencmsgs rIr HTTPRequest.read_request_headerssr    tzz4>> : {{00 T^^''(91=>B BI  .!    ! !Z /~~!!-5A(,% ^^   s 3} D$(D !  ! !Z /##$89B13$MA779'aggioo'M! *$(,D%(()<=,0D) 6 >>  i - @((KK((//8# C  %%c*o   !2BGGAJ ?    !2   :N^<< 771:V%C%CCD sL&H4%I*)J "J  %J4 I'>I""I'*J J K%"K  KcURRnUR(a&[URR U5UlOz[ URRSS55nU(a)X:a$UR(dURSS5 g[URR U5UlURRU5R5 UR=(a UR5 UR (a&URR"R%S5 gg)z/Call the gateway and write its iterable output.rrrrNs0 )rr'rr rrBrrr?rrrgatewayrespondrensure_headers_sentrr*r+)rAr/r0s rIr7HTTPRequest.respondEs{{00   %diiootB ((((61 )$))//2>DJ D!))+ 1t//1    IIOO ! !, / r'c[U5nURR<SU<S3nS[U5-nSnUR S5UR S5UR S5/nUSSS;a+S UlUR S :XaURS 5 OS nUR[5 U(a7[U[5(aUR S5nURU5 URRR[RU55 g![R a,nUR"S [$R&;aeSnAgSnAff=f)z+Write a simple response back to the client. z zContent-Length: %s zContent-Type: text/plain ISO-8859-1N>413414Tr sConnection: close rr)strrrrqr)rrrzr5 isinstancerr*r+r|r@r,r-rrr.)rArr3 proto_statusr content_typebufrs rIrHTTPRequest.simple_response\s*V&*kk&:&:FC 1CH<5    -  ! !, /    -  "1: '$(D !%%3 34+ 4 #s##jj. JJsO  IIOO ! !%**S/ 2|| wwqz!?!??@ s48D--E-"E((E-cVUR(dSUlUR5 gg)z:Ensure headers are sent to the client if not already sent.TN)r send_headersrks rIr8HTTPRequest.ensure_headers_sents$  $D     !r'cXUR(atU(am[[U55SSRS5nU[U[/nUR R R[RU55 gUR R RU5 g)z$Write unbuffered data to the client.rNr%) rhexrqr)r5rr*r+r|r@)rArchunk_size_hexrDs rIr+HTTPRequest.writesn   % U_QR077@N!45C IIOO ! !%**S/ 2 IIOO ! !% (r'cURVVs/sHupUR5PM nnn[URSS5nUS:XaSUlOiSU;acUS:dUS;aOVUR S:H=(a UR S :gnU(a#SUlURRS 5 OSUlUR(d"URRnU(+UlS U;aiUR S:Xa-UR(aURRS 5 O,UR(dURRS 5 S UR;aCURRSSURR3RS545 UR(dIUR(d8[URSS5nUS:aURR!U5 SU;aGURRS["R$R'SS9RS545 SU;a@URRSURR(RS545 URR*RS5nU[,-UR-[.-/n URH.upU RU [0-[,-U -[.-5 M0 U R[.5 UR2R4R7[8R;U 55 gs snnf)zAssert, process, and send the HTTP response message-headers. You must set ``self.status``, and :py:attr:`self.outheaders ` before calling this. Nr=iTscontent-lengthr/>0r sHEAD)r,r$s connection)r*r!)r*r"r"ztimeout=r<rrsdatesDate)usegmtsserversServerr%)rr(rrrrrrrzrcan_add_keepalive_connectiontimeoutr)rgetattrrBrpemailutils formatdate server_namerr7r5r;rr*r+r|r@) rAkeyvaluehkeysr needs_chunkedcan_keeprprotorDrGrFs rIrGHTTPRequest.send_headerss 04??T[[!_% S=$(D ! e +|v8**j8/ w.!)-D&OO**+MN-1D)$${{??H(0LD !  %%%3((OO**+DE**&&'EF )T__ < OO " "!t{{2234;;LI %%0A0A  K;I1}  * %  OO " "KK**$*7>>|L  E ! OO " "KK++22<@  $$++G4u}t{{*T12OODA JJq5y5(1,t3 4$ 4 ejjo.m@sM/)rrrrrrrrrrrrrrrBrrrrrrr)FT)r)rUrVrWrXrYrrrrrrrrr&rgrrrr7rr8r+rGrZrMr'rIrrs F@ DDI$J; E@M<!NM'B DcJbH0.#J )\/r'rc\rSrSrSrSrSrSr\Rr \Rr \ r SrSrSr\4SjrSrSrSrSrS rS r\S 5r\S 5r\S 5rSr\S5r\S5rSr Sr!g)riz#An HTTP connection (active socket).NFcrXlX lU"USUR5UlU"USUR5UlSUlURRUlURRUl[SS9"UR5Ul [SS9"UR5Ul g)aInitialize 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,rbufsizerBwbufsizer* requests_seenpeercreds_enabledpeercreds_resolve_enabledrresolve_peer_credsget_peer_creds)rArsockmakefiles rIrgHTTPConnection.__init__s  dD$--8 dD$--8 !%!>!>)-)N)N&#,A"6t7N7N"O'243F3FGr'cSnURURU5nUR5 URRS(aU=RS- slUR (dgSnUR 5 UR(dgg![RanURSnSnXE;a6U(aW(a#UR(aURWS5 S nAgU[R;aGURRS[!U5-["R$SS 9 URWS 5 S nAgS nAf[&[(4a e[R*a g[R,a UR/W5 g[0aNnURR[!U5["R2SS 9 URWS 5 S nAgS nAff=f) zbRead 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)RequestHandlerClassrrstatsrgrr7rr,r-rr_conditional_errorrr. error_logrloggingWARNINGKeyboardInterrupt SystemExit FatalSSLAlert NoSSLError_handle_no_ssl ExceptionERROR)rA request_seenreqrerrnum timeout_errss rI communicateHTTPConnection.communicates  - F**4;;=C    {{  +""a'"99L KKM''(B?|| JWWQZFFL% %##2E2E++C1FG*)v=== %%%V 4!//"& ''-HI":.  ##     %    $ F KK ! !Rmm "   # #C)D E E Fs?A0B5#BH/AE;AE'H$H* H3AG<<HcU(aUR(agURRn[ USUR 5UlSnURSU5 SUl g![a URRnNZf=f)NrczUThe client sent a plain HTTP request, but this server only speaks HTTPS on this port.rT) rr,_sockAttributeError_socketr rfr*rlinger)rAr resp_sockr3s rIr~HTTPConnection._handle_no_sslMs~c&&  , ))I")T4==A  :  -s3  , ++I ,sA)) B  B cU(aUR(agURU5 g![Ra g[Ra UR U5 gf=f)z^Respond with an error. Don't bother writing if a response has already started being written. N)rrrr|r}r~)rArresponses rIrv!HTTPConnection._conditional_error^sY c&&  %    )##     %    $ %s-A*$A*)A*cURR5 UR(d+UR5 URR5 gg)z,Close the socket underlying this connection.N)rBrr_close_kernel_socketr,rks rIrHTTPConnection.closens< {{  % % ' KK    r'cSn[(d(URR[R:wa [ S5eUR (d [ S5eURR[R[R[R"U55n[R"X5up4nX4U4$![Ra n[ UeSnAff=f)abReturn 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_UNIXNotImplementedErrorrh RuntimeError getsockopt SOL_SOCKETrstructcalcsizeunpackr-)rAPEERCRED_STRUCT_DEF peer_credspiduidgid socket_errs rIrkHTTPConnection.get_peer_credss# :++v~~=%G %%B  !//!!"" 34 J"#MM*=JMCcS= || / J . /sA CC)C$$C)c.UR5un nU$)z,Return the id of the connected peer process.rk)rArr]s rIpeer_pidHTTPConnection.peer_pids'') Q r'c,UR5upnU$)z1Return the user id of the connected peer process.r)rAr]rs rIpeer_uidHTTPConnection.peer_uids'')  r'c,UR5u pU$)z2Return the group id of the connected peer process.r)rAr]rs rIpeer_gidHTTPConnection.peer_gids'') 1 r'c[(d [S5eUR(d [S5e[R "UR 5Rn[R"UR5RnX4$)zLook 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_RESOLVABLErrirpwdgetpwuidrpw_namegrpgetgrgidrgr_name)rAusergroups rIrj!HTTPConnection.resolve_peer_credssq%$%6  --? ||DMM*22 T]]+33{r'c*UR5upU$)z2Return the username of the connected peer process.rj)rArr]s rI peer_userHTTPConnection.peer_users))+ r'c*UR5upU$)z/Return the group of the connected peer process.r)rAr]rs rI peer_groupHTTPConnection.peer_groups**, r'c2[URSURR5nU"[R5 g![R a g[R a)nUR[R;aeSnAgSnAff=f)z0Terminate the connection at the transport level. sock_shutdownN) rTr,shutdown SHUT_RDWRr#acceptable_sock_shutdown_exceptionsr-errno$acceptable_sock_shutdown_error_codes)rAres rIr#HTTPConnection._close_kernel_socketsx KK  KK     V%% &99  || wwfIIIJ sABB-BB) rkrrhrirgrjrBrr,r*)"rUrVrWrXrY remote_addr remote_portssl_envioDEFAULT_BUFFER_SIZErerfrrtrhri last_usedr rgrrr~rvrrkpropertyrrrrjrrrrZrMr'rIrrs-KKG%%H%%H% %I.6H.4lF"% &*!X   0  r'rc \rSrSrSrSrSrSrSrSr Sr Sr Sr Sr SrSrS \<3rSrS rS rS rS r\rSrS rS rS rSrS(S jrSrSr Sr!\"S5r#\#RHS5r#Sr%Sr&Sr'Sr(Sr)\*RVS5r,\"S5r-Sr.S)Sjr/S*Sjr0Sr1\2S5r3\4S+Sj5r5\2S 5r6\2S!5r7S"r8\"S#5r9\"S$5r:\9RHS%5r9S&r;S'r[TR5$rR)rrsrAs rI(HTTPServer.clear_stats..sd4>>&:r'zRun timecX>US(+=(a S=(d TR5$)Nrpryruntimers rIrrs$) $4#<"#||~#r'Acceptsz Accepts/secc0>USTR5- $)Nrrrs rIrrsQy\DLLN%Br'rc2>[TRSS5$)NqsizerTrrs rIrrswt}}gtDr'ThreadscD>[[TRS/55$)N_threads)rqrTrrs rIrrsWT]]J%K!Lr'z Threads Idlec2>[TRSS5$)Nidlerrs rIrrsgdmmVT&Jr'z Socket ErrorsRequestsc~US(+=(a S=(d$ [SUSR55S5$)Nrpryc36# UHoS"U5v M g7f)rNrM.0ws rI ;HTTPServer.clear_stats....sH+Ga:q!!+GWorker Threadsrsumvaluesrs rIrrs<) $4#<"#H1-=+>+E+E+GH#r' Bytes Readc~US(+=(a S=(d$ [SUSR55S5$)Nrpryc36# UHoS"U5v M g7f)rNrMrs rIrrsJ-I<##-Irrrrrs rIrrs<!I,&6%>B%JQ/?-@-G-G-IJ%r' Bytes Writtenc~US(+=(a S=(d$ [SUSR55S5$)Nrpryc36# UHoS"U5v M g7f)rNrMrs rIrrsM0L1?#A&&0Lrrrrrs rIrrs<Qy\)9(Ar(M2B0C0J0J0LM(r' Work Timec~US(+=(a S=(d$ [SUSR55S5$)Nrpryc36# UHoS"U5v M g7f)r NrMrs rIrrsI,Hq;"",Hrrrrrs rIrrs<9%5$=2$IA.>,?,F,F,HI$r'zRead Throughputc~US(+=(a S=(d$ [SUSR55S5$)Nrpryc3b# UH%nUS"U5US"U5=(d S- v M' g7f)rr ư>NrMrs rIrrs39lOA&!K.*;*CtD9-/rrrrs rIrrsCq|+;*C*/0779 *r'zWrite Throughputc~US(+=(a S=(d$ [SUSR55S5$)Nrpryc3b# UH%nUS"U5US"U5=(d S- v M' g7f)rr rNrMrs rIrrs49o&q)Q{^A->-F$G9rrrrrs rIrrsC) ,<+D"+/0779 +r'rzCheroot HTTPServer %d) _start_time _run_timerurxr-idrks`rIrHTTPServer.clear_statss0 u0 :0  0 q 0 B 0  D0  L0  J0  Q0  0 !0 * +0 4 50 >  ?0 N !O0 ^ b_0  bBF2RX=>r'cURc UR$UR[R"5UR- -$)zReturn server uptime.)rrtimerks rIrHTTPServer.runtimes8    #>> !~~t/?/?!?@@r'cnUR<SURR<SUR<S3$)z1Render Server instance representing bind address..(r)rVr`rUrrks rI__str__HTTPServer.__str__s) OO NN # # NN  r'cUR$)a+Return 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_addrrks rIrHTTPServer.bind_addrs4r'cb[U[5(aUSS;a [S5eXlg)z5Set the interface on which to listen for connections.r>NrzzHost values of '' or None are not allowed. Use '0.0.0.0' (IPv4) or '::' (IPv6) instead to listen on all active interfaces.N)rArr4r )rArZs rIrr!s7 eU # #aJ(>6   r'cUR5 g![a nURnU(dXlXeSnAf[a nURnU(dX0lX2eSnAff=f)z4Run the server forever, and stop it cleanly on exit.N)startrz interruptr{)rA kb_intr_excunderlying_interrupt sys_exit_excs rI safe_startHTTPServer.safe_startsY 9 JJL  8#'>> '!, 7 9#'>> '!- 8  9s A%8 A%A  A%c(SUlURcSUR-UlSUlSn[R "SS5(a:[R "S[R[R5UlO[UR[[45(aURUR5 OvURup4[R"UU[R [RS [R"5nUHnUuppn UR)XU 5 O UR(d[R"U5eURR-S 5 URR/UR05 [2R4"U5UlUR8R;5 SUl[>R>"5Ul g![Ra4nU<SUR<SU<S3n[R"U5UeSnAff=f![R$aQ [RnURnS U;a[R&nUS -nU[RS S U4/nGNf=f![RaLnU<SU <SU<S3nUR(aURR+5 SUlSnAGMSnAff=f)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)! _interruptsoftwarerr,osgetenvfromfdAF_INET SOCK_STREAMrArr@bytesbind_unix_socketr- getaddrinfo AF_UNSPEC AI_PASSIVEgaierrorrbindr settimeoutlistenrequest_queue_sizerConnectionManager _connectionsrr$rrr)rAr3serrhostrinfo sock_typerr}afsocktyper^ _canonnamesas rIprepareHTTPServer.preparesW  == '$,,6DM * 99\4 ( ( --6>>6;M;MNDK e 5 5 2%%dnn5JD K))$$&&%% $693e'IIbE2 {{,,s# # q! 4223(99$?  99;i<< 2*-t~~tDll3'T1 2"?? K"NN  NN $; &I )F 2I"F$6$62yIJ K||'.12tAI *J1>I/II A!J.-J.1LAL  LcUR(alURR5nU[Lag[ X5nUR S5 SUlUR!5 UR(aMkgg![ [R4a M[a<nURR[U5[RSS9 SnANSnAff=f)z(Serve connections we can't handle a 503.Nz503 Service UnavailableTrq)rrr?_STOPPING_FOR_INTERRUPTrrOSErrorrr|rrrwrrxrrr)rArrequestrs rI_serve_unservicableHTTPServer._serve_unservicableQsjj++//1D..!$-G ''(ABDK JJL+jjjV112   %%H!--"&  sA??C! C!%2CC!c[R"URS9R5 UR(a[UR (dJUR RUR5 UR(aUR (dMJUR (aXUR(a)[ R""S5 UR(aM)UR (a UR egg![[4a e[a" URS[RSS9 Nf=f)z1Serve requests, after invoking :func:`prepare()`.targetzError in HTTPServer.serveTrqg?N) threadingThreadrOr$rr%r@runexpiration_intervalrzr{rrwrxr_stopping_for_interruptrsleeprks rIserveHTTPServer.servejs  8 89??Ajj !!%%d&>&>?jj >>.. 3...~~nn$ &z2  /!--" s%D9D?>D?cDUR5 UR5 g)z]Run the server forever. It is shortcut for invoking :func:`prepare()` then :func:`serve()`. N)rIrZrks rIr$HTTPServer.starts  r'c## UR5 [R"URS9nSUlUR 5 Uv UR 5 g!UR 5 f=f7f)z4Context manager for running this server in a thread.rRTN)rIrTrUrZdaemonr$stop)rAthreads rI_run_in_threadHTTPServer._run_in_threadsP !!4   L IIKDIIKsAA3 A A3A00A3cTUR=(a URR$)z>Flag whether it is allowed to add a new keep-alive connection.)rr@rRrks rIrR'HTTPServer.can_add_keepalive_connectionszzLd//LLLr'c~UR(aURRU5 gUR5 g)z7Put an idle connection back into the ConnectionManager.N)rr@putrrArs rIput_connHTTPServer.put_conns( ::    ! !$ ' JJLr'c:[RRU<S35 [RR5 U(aS[R "5n[RRU5 [RR5 gg)zWrite error message to log. :param msg: error message :type msg: str :param level: logging level :type level: int :param traceback: add traceback to output or not :type traceback: bool  N)sysstderrr+flush traceback_ format_exc)rAr3rrrstbliness rIrwHTTPServer.error_logsd C7"&   ++-G JJ  W % JJ    r'c URURUUUURURUR5nUR X@R5=o@lURU5UlU$)z.Create (or recreate) the actual socket object.)prepare_socketrnodelayrr bind_socketr,resolve_real_bind_addr)rArtyper^rls rIr;HTTPServer.bindsk"" NN    LL    OO "--dNNCC{44T: r'c [(a [S5eSn[R"UR5 URU[R[RSURURURS 9n[R"UR!5U5 S nUR#Xa5nUR)U5nU(d[R*"X5 S nU(dUR1S [2R4S9 XlX`l U$![ a N[ an[U5nSU;aeSnAGNSnAf[a)n[U5nSU;a SU;aSU;aeSnAGNNSnAff=f![ a S nNf=f![R$a UR'5 ef=f![,a [R."XS S 9 Nf=f![ a GNf=f)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)rrryr^rvrrTF)follow_symlinksz(Failed to set socket fs mode permissions)rr)rr4r0unlinkrrM TypeErrorr@rur,rr4rvrrfchmodfilenorwr-rrxlchmodrchmodrwrxry)rArfs_permissionstyp_errerr_msgval_errrl FS_PERMS_SETs rIr6HTTPServer.bind_unix_sockets : B   IIdnn %,"">>##LL((#  ! B IIdkkm^ 4L ##D4D //5   COIIi8 $  NN:oo   #  E   'lG9@GHH 'lG9H(7F 2 ! L ! ||  JJL  &OHHYNO   s} D+ (F4F#G1 G 6G1+ F7 FE F%F  F F F #&G  G.+G1-G..G11 G?>G?cPUSSup#US:HnUR[R[R1;a [ S5eU(a [ S5e[ [S5(a0UR [R[RS5 g[ [S5(a0UR [R[RS5 g[(a0UR [R[RS5 g[S5e) NrrzCannot reuse a non-IP socketz"Cannot reuse an ephemeral port (0)SO_REUSEPORT_LBr SO_REUSEPORTz,Current platform does not support port reuse) rr,r3rr4hasattr setsockoptrrrr SO_REUSEADDRr)socket_r_hostrIS_EPHEMERAL_PORTs rI_make_socket_reusable HTTPServer._make_socket_reusable!sm  AI >>&..&//!B B;< < AB B 6, - -   v00&2H2H! L V^ , ,   v00&2E2Eq I Z   v00&2E2Eq I%> r'cV[R"X#U5n[R"U5 USSupU S:Hn U(aURXS9 [(d7U (d0UR [R [RS5 U(aJ[U[[45(d/UR [R[RS5 UbURU5n[[S5=(a U[R:H=(a U S;n U (ac[ R""[$[R&5 UR [R([R*S5 SSS5 U$U$!,(df  U$=f)z%Create and prepare the socket object.Nrrrrrr>::::0 ::0.0.0.0)r,rprevent_socket_inheritancerrrrrrAr@r5 IPPROTO_TCP TCP_NODELAYr;rrrrrr-rr) clsrrryr^rvrrrlrBrrlistening_ipv6s rIruHTTPServer.prepare_socket;sK}}V51..t4r]  AI   % %d % H /  OOF--v/B/BA F :i#u>> OOF..0B0BA F  "##D)D FJ ' 3&//) 322  $$^V\\B''&&C t CB s 0F F(c(URU5 U$)z#Bind the socket to given interface.)r;rs rIrwHTTPServer.bind_socketvs  Yr'cUR5nUR[R[R1;aUSS$[ U[ 5(a [U5nU$)z/Retrieve actual bind address from bound socket.Nr) getsocknamerr,r3rrAr5r rs rIrx!HTTPServer.resolve_real_bind_addr|s` '') >> NN OO   Ra= i ' 'YIr'cURRU5 g![Ra URRU5 gf=f)z#Process an incoming HTTPConnection.N)rrgrFullrrhs rI process_connHTTPServer.process_conns@ / MM  d #zz /  $ $ ( ( . /s/AAcUR$)zFlag interrupt of the server.)r.rks rIr%HTTPServer.interruptsr'c&UR[L$)z8Return whether the server is responding to an interrupt.)r.rLrks rIrX"HTTPServer._stopping_for_interrupts"999r'c[Ul[U[5(aUR S5 [U[ 5(aUR S5 UR 5 Xlg)zPerform 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)rLr.rArzrwr{r`)rAr%s rIr%rsN2 i!2 3 3 NN> ? i , , NN= > #r'cUR(dgSUlURR[5 URb5U=R [ R "5UR- - slSUlURR5 [USS5nU(a[UR[[45(dUR5SSup#[R "UU[R"[R$5HVnUupVpxn Sn [R"XVU5n U R'S5 U R)X#45 U R+5 MX [5US5(aUR+5 SUlURR+5 UR6RUR85 g![R,a U (aU R+5 MMf=f![R,a,n U R.S[0R2;aeSn A NSn A ff=f)z5Gracefully shutdown a server that is serving forever.NFr,rg?rr)rrrgrLrrrr@r`rTrArr@r5rr,r7r8r4r<connectrr-rrr.rrshutdown_timeout) rArlrBrr}rErFr^rG_sarrs rIr`HTTPServer.stopszz     $$%<=    ' NNdiikD,<,<< rrSrWrrr/rrr'rvrConnectionClassrrhrirkeep_alive_conn_limitrgrrrrrsetterr)rIrOrZr$rcontextmanagerrbrRrirwr;r6 staticmethodr classmethodrurwrxrr%rXr`rZrMr'rIrrsJJJGJFJK?H& /GG(G.H EMMLGN$O9K !& J2A"'*1X5LnA  6  ( 9I'V2%6   MM( Rh288t */::$$&:2r'rc$\rSrSrSrSrSrSrg)rizDBase class to interface HTTPServer with other systems, such as WSGI.cXlg)z]Initialize Gateway instance with request. Args: req (HTTPRequest): current HTTP request Nr)rArs rIrgGateway.__init__s r'c[e)z>Process the current request. Must be overridden in a subclass.)rrks rIr7Gateway.responds!!r'rN)rUrVrWrXrYrgr7rZrMr'rIrrsN"r'rz%cheroot.ssl.builtin.BuiltinSSLAdapterz&cheroot.ssl.pyopenssl.pyOpenSSLAdapter)builtin pyopensslc[UR5n[U[5(aIUR S5nXS-SnUSUn[ R UnUc[e[XS5nU$U$![a" [U[5[5S/5nN;f=f![a [SU<SU<S35ef=f)z/Return an SSL adapter class for the given name.rrNr'z' object has no attribute ') ssl_adaptersr(rAr@rfindrmmodulesKeyError __import__globalslocalsrTr)nameadapterlast_dot attr_namemod_pathmods rIrr s4::<(G'3==%qLN+ 9H% B++h'C{ c-G N7N BXwy&(RDAC B  7?K  s A8) B'8)B$#B$'C)r)KrYr email.utilsrUrrxr0platformrrer,rmrTrrsrp urllib.parser functoolsrrrrr_compatrr rmr r workersr __all__systemrr1rIS_GAErrr ImportErrorrrrrrr{r5r8r7r;rr|ASTERISKrrcompiler@rrrLr>r-rrrrr rrrrrrrMr'rIrsEAF    ..!, __ ) + ? $b ) 4 45I J'5v:N 'Cf'&*-- 6> * *  6= ) )v}%% &2F          ZZ'<)@ AB$+6w %%GD(D(N,,^^BWWt~~BY /Y /xCCL| 2| 2~ " "&79 aD  !&Ss9G''G98G9