o j@sZddlZddlZddlZddlmZddlmZmZdZGdddZ Gddde Z dS) N)Request)SocketUnreader IterUnreaderic@s6eZdZdZddZddZd ddZdd ZeZdS) ParserNcCs<||_t|drt||_nt||_d|_||_d|_dS)Nrecvr)cfghasattrrunreaderrmesg source_addr req_count)selfrsourcer rI/var/www/ai-app/venv/lib/python3.10/site-packages/gunicorn/http/parser.py__init__s    zParser.__init__cCs|S)Nrr rrr__iter__#szParser.__iter__c Cs$|jsdS|dur|durt}t|jdd}|dur+t|dr+t|dr+|}|}nd}d}d}z |durd|durd|t}|dkr_W|dur]z||WdSt y\YdSwdS||z |jj d}WnGt j tfyYW|durz||WdSt yYdSwdStjyYW|durz||WdSt yYdSwdSw|sW|durz||WdSt yYdSwdS|t|7}|dur||krW|durz||WdSt yYdSwdSq3|durz||Wwt yYwww) 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 rrtime monotonicrOSErrorbodyreadsockettimeout TimeoutErrorsslSSLWantReadErrorlen) r deadline max_bytesrtimeoutable_sock prior_timeoutdrained remainingdatarrr finish_body&s           zParser.finish_bodycCsX|jr |jr t||jd7_||j|j|j|j|_|js)t|jS)N) r should_close StopIterationr+r mesg_classrr r rrrr__next__eszParser.__next__)NN) __name__ __module__ __qualname__r/rrr+r0nextrrrrrs ?rc@seZdZeZdS) RequestParserN)r1r2r3rr/rrrrr5wsr5) rr!rgunicorn.http.messagergunicorn.http.unreaderrrrrr5rrrrs d