o Á¿i ã@sFddlZddlmZddlmZmZGdd„dƒZGdd„deƒZdS)éN)ÚRequest)ÚSocketUnreaderÚ IterUnreaderc@s4eZdZdZdd„Zdd„Zdd„Zdd „ZeZdS) ÚParserNcCs<||_t|dƒrt|ƒ|_nt|ƒ|_d|_||_d|_dS)NÚrecvr)ÚcfgÚhasattrrÚunreaderrÚmesgÚ source_addrÚ req_count)ÚselfrÚsourcer ©rúH/home/ubuntu/.local/lib/python3.10/site-packages/gunicorn/http/parser.pyÚ__init__s    zParser.__init__cCs|S)Nr©r rrrÚ__iter__szParser.__iter__cCsR|jr'z|jj d¡}|r|jj d¡}|s WdSWdStjy&YdSwdS)zæDiscard any unread body of the current message. This should be called before returning a keepalive connection to the poller to ensure the socket doesn't appear readable due to leftover body bytes. iN)r ÚbodyÚreadÚsslÚSSLWantReadError)r ÚdatarrrÚ finish_bodysÿþûzParser.finish_bodycCsX|jr |j ¡r tƒ‚| ¡|jd7_| |j|j|j|j¡|_|js)tƒ‚|jS)Né) r Ú should_closeÚ StopIterationrr Ú mesg_classrr r rrrrÚ__next__.szParser.__next__) Ú__name__Ú __module__Ú __qualname__rrrrrÚnextrrrrr s rc@seZdZeZdS)Ú RequestParserN)rr r!rrrrrrr#@sr#)rÚgunicorn.http.messagerÚgunicorn.http.unreaderrrrr#rrrrÚs  5