آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ U 'â7`مم@s‍ddlZddlmZddlmZmZmZddlmZddl m Z mZmZm Z ddlmZddlmZmZdd lmZmZmZGd d„deeeeefƒZdS)éN)عsuppress)عAnyعOptionalعTupleé)عBaseProtocol)ع ClientOSErrorعClientPayloadErrorعServerDisconnectedErrorعServerTimeoutError)عBaseTimerContext)عHttpResponseParserعRawResponseMessage)ع EMPTY_PAYLOADع DataQueueعStreamReaderc sPeZdZdZejddœdd„Zeedœdd„ƒZ eedœd d „ƒZ ddœdd„Zddœd d„Zedœdd„Z eeddœ‡fdd„Zddœdd„Zddœ‡fdd„Zddœ‡fdd„Zeddœ‡fdd„Zeeddœdd„Zdddd dd!d"œeeeeeeeedd#œd$d%„Zddœd&d'„Zddœd(d)„Zddœd*d+„Zedd,œd-d.„Z‡Z S)/عResponseHandlerz8Helper class to adapt between Protocol and StreamReader.N)عloopعreturncCsZtj||dچt ||،d|_d|_d|_d|_d|_d|_d|_ d|_ d|_d|_dS)N)rFَ) rع__init__rع _should_closeع_payloadع _skip_payloadع_payload_parserZ_timerع_tailع _upgradedع_parserع _read_timeoutع_read_timeout_handle)عselfr©r!ْG/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/client_proto.pyrszResponseHandler.__init__)rcCs|jS©N)r©r r!r!r"عupgraded'szResponseHandler.upgradedcCsV|jdk r|j ،r|jrdS|jpT|jpT| ،dk pT|jdk pTt|ƒdkpTt|jƒS)NTr) rعis_eofrrع exceptionrعlenعboolrr$r!r!r"عshould_close+sے ‏‎ üْzResponseHandler.should_closecCs d|_dS©NT)rr$r!r!r"عforce_close9szResponseHandler.force_closecCs.|j}|dk r*| ،d|_d|_| ،dSr#)ع transportعcloserع _drop_timeout)r r-r!r!r"r.<szResponseHandler.closecCs|jdk o|j ،Sr#)r-Z is_closingr$r!r!r"عis_connectedDszResponseHandler.is_connected)عexcrc sà| ،|jdk r0ttƒڈ|j ،W5QRXd}|jdk r|z|j ،}Wn.tk rz|jdk rv|j tdƒ،YnX| ،s²t |tƒrکt|j ژ}|dkr¨t|ƒ}| |،d|_d|_d|_d|_d|_tƒ |،dS)Nz!Response payload is not completedTF)r/rrع ExceptionZfeed_eofrrع set_exceptionr r&ع isinstanceعOSErrorrعargsr rZ_reading_pausedعsuperعconnection_lost)r r1Zuncompleted©ع __class__r!r"r8Gs2 ے zResponseHandler.connection_lostcCs| ،dSr#)r/r$r!r!r"عeof_receivediszResponseHandler.eof_receivedcstƒ ،| ،dSr#)r7ع pause_readingr/r$r9r!r"r<ms zResponseHandler.pause_readingcstƒ ،| ،dSr#)r7عresume_readingع_reschedule_timeoutr$r9r!r"r=qs zResponseHandler.resume_readingcsd|_| ،tƒ |،dSr+)rr/r7r3©r r1r9r!r"r3uszResponseHandler.set_exception)عparserعpayloadrcCs6||_||_| ،|jr2|jd}|_| |،dS)Nr)rrr/rع data_received)r r@rAعdatar!r!r"ع set_parserzszResponseHandler.set_parserFTi)عtimerعskip_payloadعread_until_eofعauto_decompressعread_timeoutعread_bufsize)rErFrGrHrIrJrc CsT||_||_| ،t||j||t|||dچ|_|jrP|jd}|_| |،dS)N)rEZpayload_exceptionZresponse_with_bodyrGrHr) rrr>r ع_loopr rrrB)r rErFrGrHrIrJrCr!r!r"عset_response_params‰s ّz#ResponseHandler.set_response_paramscCs|jdk r|j ،d|_dSr#)rعcancelr$r!r!r"r/§s zResponseHandler._drop_timeoutcCs<|j}|jdk r|j ،|r2|j ||j،|_nd|_dSr#)rrrMrKZ call_laterع_on_read_timeout)r عtimeoutr!r!r"r>¬s ےz#ResponseHandler._reschedule_timeoutcCs,tdƒ}| |،|jdk r(|j |،dS)Nz#Timeout on reading data from socket)rr3rr?r!r!r"rN¸s z ResponseHandler._on_read_timeout)rCrc Csx| ،|sdS|jdk rL|j |،\}}|rHd|_d|_|rH| |،dS|js\|jdkrn|j|7_گnz|j |،\}}}WnFtk rت}z(|j dk rھ|j ،| |،WY¢dSd}~XYnX||_d}|D]P\}}|jrîd|_ ||_|jگs|jdkگr| |tfd،qع| ||fd،qع|dk گrV|tk گrN| |j،n| ،|گrt|گrn| |،n||_dS)NT)éجi0r)r>rZ feed_datarrBrrrع BaseExceptionr-r.r3r*rrعcoderZon_eofr/) r rCعeofعtailعmessagesr%r1rAعmessager!r!r"rB¾sJ zResponseHandler.data_received)!ع__name__ع __module__ع__qualname__ع__doc__عasyncioZAbstractEventLooprعpropertyr)r%r*r,r.r0rrQr8r;r<r=r3rrDrعfloatعintrLr/r>rNعbytesrBع __classcell__r!r!r9r"rsD "ّ÷r)r[ع contextlibrعtypingrrrZ base_protocolrZclient_exceptionsrr r rZhelpersrعhttpr rZstreamsrrrrr!r!r!r"عs