آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ 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_eofrrZ 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 r0Zuncompleted©ع __class__r!r"r7Gs2 ے zResponseHandler.connection_lostcCs| ،dSr#)r.r$r!r!r"عeof_receivediszResponseHandler.eof_receivedcstƒ ،| ،dSr#)r6ع pause_readingr.r$r8r!r"r;ms zResponseHandler.pause_readingcstƒ ،| ،dSr#)r6عresume_readingع_reschedule_timeoutr$r8r!r"r<qs zResponseHandler.resume_readingcsd|_| ،tƒ |،dSr*)rr.r6r2©r r0r8r!r"r2uszResponseHandler.set_exception)عparserعpayloadrcCs6||_||_| ،|jr2|jd}|_| |،dS)Nr)rrr.rع data_received)r r?r@عdatar!r!r"ع set_parserzszResponseHandler.set_parserFTi)عtimerعskip_payloadعread_until_eofعauto_decompressعread_timeoutعread_bufsize)rDrErFrGrHrIrc CsT||_||_| ،t||j||t|||dچ|_|jrP|jd}|_| |،dS)N)rDZpayload_exceptionZresponse_with_bodyrFrGr) rrr=r ع_loopr rrrA)r rDrErFrGrHrIrBr!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#)rrrLrJZ 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)rr2rr>r!r!r"rM¸s z ResponseHandler._on_read_timeout)rBrc 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_datarrArrrع BaseExceptionr,r-r2r)rrعcoderZon_eofr.) r rBعeofعtailZmessagesr%r0r@عmessager!r!r"rA¾sJ zResponseHandler.data_received)!ع__name__ع __module__ع__qualname__ع__doc__عasyncioZAbstractEventLooprعpropertyr(r%r)r+r-r/rrPr7r:r;r<r2rrCrعfloatعintrKr.r=rMعbytesrAع __classcell__r!r!r8r"rsD "ّ÷r)rYع contextlibrعtypingrrrZ base_protocolrZclient_exceptionsrr r rZhelpersrZhttpr rZstreamsrrrrr!r!r!r"عs