آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ 3 \ک_م@sHdddddddgZddlZeed ƒr2ejd dgƒdd lmZddlmZddlmZddlmZddlm Z ddl mZd!ZGdd„de ƒZGdd„deƒZe d"dedœdd„ƒZe d#dedœdd„ƒZeed ƒگre d$dedœdd „ƒZe d%dedœdd„ƒZGdd„dejƒZGdd„deejƒZGdd„dƒZGd d„dƒZdS)&عStreamReaderعStreamWriterعStreamReaderProtocolعopen_connectionعstart_serverعIncompleteReadErrorعLimitOverrunErroréNZAF_UNIXعopen_unix_connectionعstart_unix_serveré)ع coroutines)عcompat)عevents)ع protocols)ع coroutine)عloggeréécs$eZdZ‡fdd„Zdd„Z‡ZS)rcs(tƒjdt|ƒ|fƒ||_||_dS)Nz-%d bytes read on a total of %r expected bytes)عsuperع__init__عlenعpartialعexpected)عselfrr)ع __class__©ْ'/usr/lib64/python3.6/asyncio/streams.pyr szIncompleteReadError.__init__cCst|ƒ|j|jffS)N)عtyperr)rrrrع __reduce__&szIncompleteReadError.__reduce__)ع__name__ع __module__ع__qualname__rrع __classcell__rr)rrrscs$eZdZ‡fdd„Zdd„Z‡ZS)rcstƒj|ƒ||_dS)N)rrعconsumed)rعmessager#)rrrr0szLimitOverrunError.__init__cCst|ƒ|jd|jffS)Nr)rعargsr#)rrrrr4szLimitOverrunError.__reduce__)rr r!rrr"rr)rrr*s)عloopعlimitc +sb|dkrtjƒ}t||dچ}t||dچ‰|j‡fdd„||f|ژEdH\}}t|ˆ||ƒ}||fS)N)r'r&)r&csˆS)Nrr)عprotocolrrعQsz!open_connection..)rعget_event_looprrZcreate_connectionr) عhostعportr&r'عkwdsعreaderع transportع_عwriterr)r(rr8s c+s8ˆdkrtjƒ‰‡‡‡fdd„}ˆj|||f|ژEdHS)Ncstˆˆdچ}t|ˆˆdچ}|S)N)r'r&)r&)rr)r.r()عclient_connected_cbr'r&rrعfactoryqszstart_server..factory)rr*Z create_server)r2r+r,r&r'r-r3r)r2r'r&rrVsc+s`|dkrtjƒ}t||dچ}t||dچ‰|j‡fdd„|f|ژEdH\}}t|ˆ||ƒ}||fS)N)r'r&)r&csˆS)Nrr)r(rrr)†sz&open_unix_connection..)rr*rrZcreate_unix_connectionr)عpathr&r'r-r.r/r0r1r)r(rr }sc+s6ˆdkrtjƒ‰‡‡‡fdd„}ˆj||f|ژEdHS)Ncstˆˆdچ}t|ˆˆdچ}|S)N)r'r&)r&)rr)r.r()r2r'r&rrr3‘sz"start_unix_server..factory)rr*Zcreate_unix_server)r2r4r&r'r-r3r)r2r'r&rr ٹsc@s:eZdZddd„Zdd„Zdd„Zdd „Zed d„ƒZdS) عFlowControlMixinNcCs0|dkrtjƒ|_n||_d|_d|_d|_dS)NF)rr*ع_loopع_pausedع _drain_waiterع_connection_lost)rr&rrrr¤szFlowControlMixin.__init__cCs d|_|jjƒrtjd|ƒdS)NTz%r pauses writing)r7r6ع get_debugrعdebug)rrrrع pause_writings zFlowControlMixin.pause_writingcCsFd|_|jjƒrtjd|ƒ|j}|dk rBd|_|jƒsB|jdƒdS)NFz%r resumes writing)r7r6r:rr;r8عdoneع set_result)rعwaiterrrrعresume_writing³s zFlowControlMixin.resume_writingcCsVd|_|jsdS|j}|dkr"dSd|_|jƒr4dS|dkrH|jdƒn |j|ƒdS)NT)r9r7r8r=r>ع set_exception)rعexcr?rrrعconnection_lost؟sz FlowControlMixin.connection_lostccs<|jrtdƒ‚|jsdS|j}|jjƒ}||_|EdHdS)NzConnection lost)r9عConnectionResetErrorr7r8r6ع create_future)rr?rrrع _drain_helperدs zFlowControlMixin._drain_helper)N) rr r!rr<r@rCrrFrrrrr5ڑs r5csBeZdZd‡fdd„ Zdd„Z‡fdd„Zdd „Zd d„Z‡ZS) rNcs*tƒj|dچ||_d|_||_d|_dS)N)r&F)rrع_stream_readerع_stream_writerع_client_connected_cbع _over_ssl)rZ stream_readerr2r&)rrrrهs zStreamReaderProtocol.__init__cCsd|jj|ƒ|jdƒdk |_|jdk r`t|||j|jƒ|_|j|j|jƒ}tj |ƒr`|jj |ƒdS)NZ sslcontext)rGع set_transportعget_extra_inforJrIrr6rHrZiscoroutineZcreate_task)rr/عresrrrعconnection_madeىs z$StreamReaderProtocol.connection_madecsF|jdk r*|dkr|jjƒn|jj|ƒtƒj|ƒd|_d|_dS)N)rGعfeed_eofrArrCrH)rrB)rrrrCّs z$StreamReaderProtocol.connection_lostcCs|jj|ƒdS)N)rGع feed_data)rعdatarrrع data_receivedsz"StreamReaderProtocol.data_receivedcCs|jjƒ|jrdSdS)NFT)rGrOrJ)rrrrعeof_receiveds z!StreamReaderProtocol.eof_received)NN) rr r!rrNrCrRrSr"rr)rrrـs c@sfeZdZdd„Zdd„Zedd„ƒZdd„Zd d „Zdd„Z d d„Z dd„Zddd„Ze dd„ƒZdS)rcCs||_||_||_||_dS)N)ع _transportع _protocolع_readerr6)rr/r(r.r&rrrrszStreamWriter.__init__cCs:|jjd|jg}|jdk r,|jd|jƒddj|ƒS)Nztransport=%rz reader=%rz<%s>ْ )rrrTrVعappendعjoin)rعinforrrع__repr__!s zStreamWriter.__repr__cCs|jS)N)rT)rrrrr/'szStreamWriter.transportcCs|jj|ƒdS)N)rTعwrite)rrQrrrr\+szStreamWriter.writecCs|jj|ƒdS)N)rTع writelines)rrQrrrr].szStreamWriter.writelinescCs |jjƒS)N)rTع write_eof)rrrrr^1szStreamWriter.write_eofcCs |jjƒS)N)rTع can_write_eof)rrrrr_4szStreamWriter.can_write_eofcCs |jjƒS)N)rTعclose)rrrrr`7szStreamWriter.closeNcCs|jj||ƒS)N)rTrL)rعnameعdefaultrrrrL:szStreamWriter.get_extra_infoccsN|jdk r |jjƒ}|dk r |‚|jdk r:|jjƒr:dV|jjƒEdHdS)N)rVع exceptionrTZ is_closingrUrF)rrBrrrعdrain=s zStreamWriter.drain)N)rr r!rr[عpropertyr/r\r]r^r_r`rLrrdrrrrrs c@sخeZdZedfdd„Zdd„Zdd„Zdd „Zd d„Zdd „Z dd„Z dd„Zdd„Zdd„Z edd„ƒZedd„ƒZed'dd„ƒZed)dd„ƒZed d!„ƒZejr¼ed"d#„ƒZed$d%„ƒZejrتd&d#„ZdS)*rNcCsZ|dkrtdƒ‚||_|dkr*tjƒ|_n||_tƒ|_d|_d|_d|_ d|_ d|_dS)NrzLimit cannot be <= 0F)ع ValueErrorع_limitrr*r6ع bytearrayع_bufferع_eofع_waiterع _exceptionrTr7)rr'r&rrrrXszStreamReader.__init__cCsھdg}|jr |jdt|jƒƒ|jr0|jdƒ|jtkrJ|jd|jƒ|jr`|jd|jƒ|jrv|jd|jƒ|jrŒ|jd|jƒ|j rœ|jdƒd d j |ƒS)Nrz%d bytesعeofzl=%dzw=%rze=%rzt=%rZpausedz<%s>rW)rirXrrjrgع_DEFAULT_LIMITrkrlrTr7rY)rrZrrrr[ks zStreamReader.__repr__cCs|jS)N)rl)rrrrrc}szStreamReader.exceptioncCs0||_|j}|dk r,d|_|jƒs,|j|ƒdS)N)rlrkع cancelledrA)rrBr?rrrrA€szStreamReader.set_exceptioncCs*|j}|dk r&d|_|jƒs&|jdƒdS)N)rkror>)rr?rrrع_wakeup_waiter‰s zStreamReader._wakeup_waitercCs ||_dS)N)rT)rr/rrrrK‘szStreamReader.set_transportcCs*|jr&t|jƒ|jkr&d|_|jjƒdS)NF)r7rrirgrTعresume_reading)rrrrع_maybe_resume_transport•sz$StreamReader._maybe_resume_transportcCsd|_|jƒdS)NT)rjrp)rrrrrOڑszStreamReader.feed_eofcCs|jo|jS)N)rjri)rrrrعat_eof‍szStreamReader.at_eofcCsv|sdS|jj|ƒ|jƒ|jdk rr|jrrt|jƒd|jkrry|jjƒWntk rjd|_YnXd|_dS)NrT) riعextendrprTr7rrgZ pause_readingعNotImplementedError)rrQrrrrP¢s zStreamReader.feed_dataccsV|jdk rtd|ƒ‚|jr,d|_|jjƒ|jjƒ|_z|jEdHWdd|_XdS)NzH%s() called while another coroutine is already waiting for incoming dataF)rkعRuntimeErrorr7rTrqr6rE)rZ func_namerrrع_wait_for_data¸s zStreamReader._wait_for_dataccs¬d}t|ƒ}y|j|ƒEdH}Wn†tk rB}z|jSd}~Xnftk r¦}zJ|jj||jƒrv|jd|j|…=n |jjƒ|j ƒt |jdƒ‚WYdd}~XnX|S)Nَ r)rع readuntilrrrriع startswithr#عclearrrrfr%)rعsepعseplenعlineعerrrعreadlineشs zStreamReader.readlinerxccsْt|ƒ}|dkrtdƒ‚|jdk r(|j‚d}x†t|jƒ}|||kr||jj||ƒ}|dkr\P|d|}||jkr|td|ƒ‚|jr t|jƒ}|jj ƒt |dƒ‚|jdƒEdHq.W||jkrبtd|ƒ‚|jd||…}|jd||…=|jƒt|ƒS)Nrz,Separator should be at least one-byte stringrz2Separator is not found, and chunk exceed the limitryz2Separator is found, but chunk is longer than limitéےےےے) rrfrlriعfindrgrrjعbytesr{rrwrr)rZ separatorr}عoffsetZbuflenZisepعchunkrrrryôs: zStreamReader.readuntilrccs¤|jdk r|j‚|dkrdS|dkrZg}x&|j|jƒEdH}|sBP|j|ƒq*Wdj|ƒS|jrz|jrz|jdƒEdHt|jd|…ƒ}|jd|…=|j ƒ|S)Nrَعread) rlr‡rgrXrYrirjrwrƒrr)rعnZblocksعblockrQrrrr‡Ps$ zStreamReader.readccsآ|dkrtdƒ‚|jdk r |j‚|dkr,dSxFt|jƒ|krr|jr`t|jƒ}|jjƒt||ƒ‚|jdƒEdHq.Wt|jƒ|krکt|jƒ}|jjƒnt|jd|…ƒ}|jd|…=|j ƒ|S)Nrz*readexactly size can not be less than zeror†عreadexactly) rfrlrrirjrƒr{rrwrr)rrˆZ incompleterQrrrrٹƒs& zStreamReader.readexactlycCs|S)Nr)rrrrع __aiter__®szStreamReader.__aiter__ccs|jƒEdH}|dkrt‚|S)Nr†)r€عStopAsyncIteration)rعvalrrrع __anext__²szStreamReader.__anext__cCs|S)Nr)rrrrr‹¼s)rxrپ)rپ)rr r!rnrr[rcrArprKrrrOrsrPrrwr€ryr‡rٹr ZPY35r‹rژZPY352rrrrrVs, [2*i)NN)NN)N)N)ع__all__Zsocketعhasattrrtعrr rrrعlogrrnعEOFErrorrع Exceptionrrrr r ZProtocolr5rrrrrrrعs@ "B3G