??? 123123123123 .....................................................................................................................................??? 123123123123 .....................................................................................................................................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_writingнs 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