\JjfddlZddlZddlZddlmZddlmZmZdZGddZ Gdde Z y) N)Request)SocketUnreader IterUnreaderic.eZdZdZdZdZddZdZeZy)ParserNc||_t|drt||_nt ||_d|_||_d|_y)Nrecvr)cfghasattrrunreaderrmesg source_addr req_count)selfr sourcers O/var/www/html/Extract/venv/lib/python3.12/site-packages/gunicorn/http/parser.py__init__zParser.__init__sC 66 "*62DM(0DM &c|S)Nrs r__iter__zParser.__iter__#s rc|jsy||t}t|jdd}|+t |drt |dr|}|j }nd}d}d} |F|D|t jz }|dkr | |j|yy|j| |jjjd}|s | |j|yy|t#|z }|||k\r | |j|yy#t$rYywxYw#tjtf$r'Y|" |j|y#t$rYywxYwytj $r'Y|" |j|y#t$rYywxYwywxYw#t$rYywxYw#t$rYywxYw#|" |j|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&sP(yy  !5(It}}fd3  l ;l@[#  OO-M#  M ',<,H (4>>+; ;I A~$ +$// >,%// : 99>>..t4D   +$// >, 3t9$(W -A +$// >,', 5!  +$// >,++  +$// >, w +$// >,s#!GDG-%D'GF"+GF1G D$#D$'FGE E"!E"&F8G<F FFFG" F.-F.1 F=<F=G&GG& G"G&!G""G&cr|jr$|jjr t|j|xjdz c_|j |j |j|j|j|_|js t|jS)N) r should_close StopIterationr1r mesg_classr r rrs r__next__zParser.__next__es 99//1/ !  !OODHHdmmT=M=Mt~~^ yy/ !yyr)NN) __name__ __module__ __qualname__r6rrr1r7nextrrrrrs#J =~  DrrceZdZeZy) RequestParserN)r8r9r:rr6rrrr=r=wsJrr=) r$r'rgunicorn.http.messagergunicorn.http.unreaderrrrrr=rrrr@s7  )? aaHFr