jtddlZddlZddlZddlmZddlmZmZdZGddZ Gdde Z dS) N)Request)SocketUnreader IterUnreaderic0eZdZdZdZdZddZdZeZdS)ParserNc||_t|drt||_nt ||_d|_||_d|_dS)Nrecvr)cfghasattrrunreaderrmesg source_addr req_count)selfr sourcers G/var/www/html/venv/lib/python3.11/site-packages/gunicorn/http/parser.py__init__zParser.__init__sW 66 " " 1*622DMM(00DM &c|S)Nrs r__iter__zParser.__iter__#s rc8|jsdS| |t}t|jdd}|7t |dr't |dr|}|}nd}d}d} |a|_|t jz }|dkr. |) ||dS#t$rYdSwxYwdS|| |jj d}n#tj tf$r/Y|) ||dS#t$rYdSwxYwdStj$r/Y|) ||dS#t$rYdSwxYwdSwxYw|s. |) ||dS#t$rYdSwxYwdS|t#|z }|4||kr. |) ||dS#t$rYdSwxYwdS#|' ||w#t$rYwwxYwwxYw) a<Discard any unread body of the current message. Called before returning a keepalive connection to the poller so the socket does not appear readable due to leftover body bytes. ``deadline`` is an absolute ``time.monotonic()`` value; when set the socket read timeout is bounded by the remaining time before each read. ``max_bytes`` caps the total drained bytes; when a deadline is given and ``max_bytes`` is left at the default, ``_DRAIN_MAX_BYTES`` applies to defend against a slow client that keeps trickling under it. When called without a deadline (the default invocation from ``__next__``), no byte cap is applied so the prior unbounded drain semantics are preserved for callers that don't know how to react to a partial drain. Returns ``True`` when the body was fully drained, ``False`` when the drain was abandoned (deadline, byte cap, or socket timeout). Callers that observe ``False`` MUST close the connection rather than serve another request on it. TNsock gettimeout settimeoutrFi)r _DRAIN_MAX_BYTESgetattrr r rtime monotonicrOSErrorbodyreadsockettimeout TimeoutErrorsslSSLWantReadErrorlen) rdeadline max_bytesrtimeoutable_sock prior_timeoutdrained remainingdatas r finish_bodyzParser.finish_body&sA(y 4  !5(It}fd33  l ; ; l@[@[ #  OO--MM#  M  !',<,H (4>+;+; ;I A~~$ +$// >>>>>DD,+%// ::: 9>..t44DD 5!!!  +$// >>>>>DD,++    +$// >>>>>DD,+    +$// >>>>>DD,+ 3t99$(W -A-A +$// >>>>>DD,+' !& +$// >>>>D,s+!G.B'' B54B5:G.C0/G.0E1G. D!! D/.D/4E1G.E E+*E+0E11G.:F FF$G.G G'&G',G..H2HH HHHHc@|jr'|jrt||xjdz c_||j|j|j|j|_|jst|jS)N) r should_close StopIterationr1r mesg_classr r rrs r__next__zParser.__next__es 9 "//11 "// !  !OODHdmT=Mt~^^ y "// !yr)NN) __name__ __module__ __qualname__r6rrr1r7nextrrrrrs\J   ====~    DDDrrceZdZeZdS) RequestParserN)r8r9r:rr6rrrr=r=wsJJJrr=) r$r'rgunicorn.http.messagergunicorn.http.unreaderrrrrr=rrrr@s  ))))))???????? aaaaaaaaHFr