B ê¹`Lã@s4dZddlmZmZGdd„dƒZGdd„dƒZdS)zData Chunk Receiver é)Ú BadRequestÚfind_double_newlinec@s<eZdZdZdZdd„Zdd„Zdd„Zd d „Zd d „Z dS) ÚFixedStreamReceiverFNcCs||_||_dS)N)ÚremainÚbuf)ÚselfZclr©rúY/home/kop/projects/devel/pgwui/test_venv/lib/python3.7/site-packages/waitress/receiver.pyÚ__init__szFixedStreamReceiver.__init__cCs |j ¡S)N)rÚ__len__)rrrr r szFixedStreamReceiver.__len__cCsn|j}|dkrd|_dSt|ƒ}||krL|j |d|…¡d|_d|_|S|j |¡|j|8_|SdS)zSee IStreamConsumeréTrN)rÚ completedÚlenrÚappend)rÚdataÚrmZdatalenrrr Úreceived!s zFixedStreamReceiver.receivedcCs |j ¡S)N)rÚgetfile)rrrr r7szFixedStreamReceiver.getfilecCs|jS)N)r)rrrr Úgetbuf:szFixedStreamReceiver.getbuf) Ú__name__Ú __module__Ú __qualname__r Úerrorr r rrrrrrr rsrc@sTeZdZdZdZdZdZdZdZdZ dZ dd„Z dd„Z d d „Z d d „Zd d„ZdS)ÚChunkedReceiverrFóNcCs ||_dS)N)r)rrrrr r LszChunkedReceiver.__init__cCs |j ¡S)N)rr )rrrr r OszChunkedReceiver.__len__c Cs.|jr dSt|ƒ}x|r(|j}|dkrv|d|…}|j |¡t|ƒ}||d…}|j|8_|jdkrtd|_q|jrä|j|}| d¡}|dkr°t|ƒdkr°||_d}n2d|_|dkrÌ|dd…}ntdƒ|_ d|_ d|_q|j s¸|j |}| d¡}|dkr||_ d}n |d|…}||dd…}d|_ |  ¡}|r&| d¡}|dkrf|d|…}yt |  ¡d ƒ} Wn$tk rœtd ƒ|_ d} YnX| dkr°| |_nd|_ q|j|} |  d¡räd|_|t| ƒdSt| ƒ}|dkr| |_d}qd|_| d|…|_|t| ƒ|SqW|S) NrTs érzChunk not properly terminatedFó;éz!garbage in chunked encoding input)r rÚchunk_remainderrrÚvalidate_chunk_endÚ chunk_endÚfindrrÚall_chunks_receivedÚ control_lineÚstripÚintÚ ValueErrorÚtrailerÚ startswithr) rÚsZ orig_sizerZto_writeZwrittenÚposÚlineÚsemiÚszr'rrr rRsv                     zChunkedReceiver.receivedcCs |j ¡S)N)rr)rrrr r¶szChunkedReceiver.getfilecCs|jS)N)r)rrrr r¹szChunkedReceiver.getbuf)rrrrrr#r r"r'r rr r rrrrrrr r>sdrN)Ú__doc__Zwaitress.utilitiesrrrrrrrr Ús*