ÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂ 3 \³Oã@súdgZddlZddlZddlmZddlmZddlmZddlmZddlmZdd lm Z dd l mZGdd„de je j ƒZGd d„dee jƒZGdd„dee jƒZGdd„deƒZGdd„deee jƒZGdd„deee jƒZGdd„dejƒZdS)ÚBaseProactorEventLoopéNé)Úbase_events)Úcompat)Ú constants)Úfutures)Ússlproto)Ú transports)Úloggercs~eZdZd‡fdd„ Zdd„Zdd„Zdd „Zd d„Zdd „Zdd„Z e jrTdd„Zddd„Z dd„Zdd„Zdd„Z‡ZS)Ú_ProactorBasePipeTransportNcs˜tƒj||ƒ|j|ƒ||_||_||_d|_d|_d|_d|_ d|_ d|_d|_|jdk rh|jj ƒ|jj|jj|ƒ|dk r”|jjtj|dƒdS)NrF)ÚsuperÚ__init__Ú _set_extraÚ_sockÚ _protocolÚ_serverÚ_bufferÚ _read_futÚ _write_futÚ_pending_writeÚ _conn_lostÚ_closingÚ_eof_writtenZ_attachÚ_loopÚ call_soonZconnection_maderZ_set_result_unless_cancelled)ÚselfÚloopÚsockÚprotocolÚwaiterÚextraÚserver)Ú __class__©ú//usr/lib64/python3.6/asyncio/proactor_events.pyr s$ z#_ProactorBasePipeTransport.__init__cCs¾|jjg}|jdkr |jdƒn|jr0|jdƒ|jdk rN|jd|jjƒƒ|jdk rh|jd|jƒ|jdk r‚|jd|jƒ|jr t |jƒ}|jd|ƒ|j r°|jdƒdd j|ƒS) NÚclosedÚclosingzfd=%szread=%szwrite=%rzwrite_bufsize=%szEOF writtenz<%s>ú )r"Ú__name__rÚappendrÚfilenorrrÚlenrÚjoin)rÚinfoÚbufsizer#r#r$Ú__repr__/s" z#_ProactorBasePipeTransport.__repr__cCs||jd<dS)NÚpipe)Ú_extra)rrr#r#r$rBsz%_ProactorBasePipeTransport._set_extracCs ||_dS)N)r)rrr#r#r$Úset_protocolEsz'_ProactorBasePipeTransport.set_protocolcCs|jS)N)r)rr#r#r$Úget_protocolHsz'_ProactorBasePipeTransport.get_protocolcCs|jS)N)r)rr#r#r$Ú is_closingKsz%_ProactorBasePipeTransport.is_closingcCs^|jr dSd|_|jd7_|jr@|jdkr@|jj|jdƒ|jdk rZ|jjƒd|_dS)NTr) rrrrrrÚ_call_connection_lostrÚcancel)rr#r#r$ÚcloseNs z _ProactorBasePipeTransport.closecCs*|jdk r&tjd|t|d|jƒdS)Nzunclosed transport %r)Úsource)rÚwarningsÚwarnÚResourceWarningr7)rr#r#r$Ú__del__]s z"_ProactorBasePipeTransport.__del__úFatal error on pipe transportcCsPt|tjƒr*|jjƒrBtjd||ddn|jj||||jdœƒ|j |ƒdS)Nz%r: %sT)Úexc_info)ÚmessageÚ exceptionZ transportr) Ú isinstancerZ_FATAL_ERROR_IGNORErÚ get_debugr ÚdebugÚcall_exception_handlerrÚ_force_close)rÚexcr?r#r#r$Ú_fatal_errorcs z'_ProactorBasePipeTransport._fatal_errorcCsj|jr dSd|_|jd7_|jr4|jjƒd|_|jrJ|jjƒd|_d|_d|_|jj|j |ƒdS)NTrr) rrrr6rrrrrr5)rrFr#r#r$rEps z'_ProactorBasePipeTransport._force_closecCs^z|jj|ƒWdt|jdƒr,|jjtjƒ|jjƒd|_|j}|dk rX|j ƒd|_XdS)NÚshutdown) rZconnection_lostÚhasattrrrHÚsocketZ SHUT_RDWRr7rZ_detach)rrFr!r#r#r$r5s z0_ProactorBasePipeTransport._call_connection_lostcCs"|j}|jdk r|t|jƒ7}|S)N)rrr+)rÚsizer#r#r$Úget_write_buffer_sizes z0_ProactorBasePipeTransport.get_write_buffer_size)NNN)r=)r(Ú __module__Ú__qualname__r r/rr2r3r4r7rZPY34r<rGrEr5rLÚ __classcell__r#r#)r"r$rs rcs8eZdZd ‡fdd„ Zdd„Zdd„Zddd „Z‡ZS)Ú_ProactorReadPipeTransportNcs4tƒj||||||ƒd|_d|_|jj|jƒdS)NF)rr Ú_pausedÚ_reschedule_on_resumerrÚ _loop_reading)rrrrrr r!)r"r#r$r ›sz#_ProactorReadPipeTransport.__init__cCs0|js|jrdSd|_|jjƒr,tjd|ƒdS)NTz%r pauses reading)rrQrrBr rC)rr#r#r$Ú pause_reading¢s z(_ProactorReadPipeTransport.pause_readingcCsP|js|jrdSd|_|jr6|jj|j|jƒd|_|jjƒrLtj d|ƒdS)NFz%r resumes reading) rrQrRrrrSrrBr rC)rr#r#r$Úresume_reading©s z)_ProactorReadPipeTransport.resume_readingcCsŽ|jrd|_dSd}z"yH|dk r0d|_|jƒ}|jr>d}dS|dkrJdS|jjj|jdƒ|_WnÆt k r®}z2|js†|j |dƒn|jjƒržtj dddWYdd}~Xnˆtk rØ}z|j|ƒWYdd}~Xn^tk r}z|j |dƒWYdd}~Xn0tjk r&|js"‚YnX|jj|jƒWd|rN|jj|ƒn:|dk rˆ|jjƒrptj d|ƒ|jjƒ}|sˆ|jƒXdS)NTóiz"Fatal read error on pipe transportz*Read error on pipe transport while closing)r>z%r received EOF)rQrRrÚresultrrÚ _proactorÚrecvrÚConnectionAbortedErrorrGrBr rCÚConnectionResetErrorrEÚOSErrorrÚCancelledErrorÚadd_done_callbackrSrZ data_receivedZeof_receivedr7)rÚfutÚdatarFZ keep_openr#r#r$rS³sH z(_ProactorReadPipeTransport._loop_reading)NNN)N)r(rMrNr rTrUrSrOr#r#)r"r$rP—s rPc@s6eZdZdd„Zddd„Zdd„Zdd „Zd d„ZdS) Ú_ProactorBaseWritePipeTransportcCs¸t|tttfƒs&dt|ƒj}t|ƒ‚|jr4tdƒ‚|sÚpeernamezgetpeername() failed on %r) r1ZgetsocknamerJÚerrorÚAttributeErrorrrBr rhZgetpeername)rrr#r#r$rfs z#_ProactorSocketTransport._set_extracCsdS)NTr#)rr#r#r$rrvsz&_ProactorSocketTransport.can_write_eofcCs2|js|jrdSd|_|jdkr.|jjtjƒdS)NT)rrrrrHrJrn)rr#r#r$rsys z"_ProactorSocketTransport.write_eof)NNN)r(rMrNr rrrrsrOr#r#)r"r$r}\s r}csÒeZdZ‡fdd„Zd-dd„Zd.dddddœdd „Zd/d d„Zd0dd „Zd1dd„Z‡fdd„Z dd„Z dd„Zdd„Zdd„Z dd„Zdd„Zdd„Zd2d d!„Zd"d#„Zd3d%d&„Zd'd(„Zd)d*„Zd+d,„Z‡ZS)4rcsHtƒjƒtjd|jjƒ||_||_d|_i|_ |j |ƒ|jƒdS)NzUsing proactor: %s)rr r rCr"r(rXÚ _selectorÚ_self_reading_futureÚ_accept_futuresZset_loopÚ_make_self_pipe)rZproactor)r"r#r$r ƒs zBaseProactorEventLoop.__init__NcCst||||||ƒS)N)r})rrrrr r!r#r#r$Ú_make_socket_transports z,BaseProactorEventLoop._make_socket_transportF)Úserver_sideÚserver_hostnamer r!c Cs<tjƒstdƒ‚tj||||||ƒ} t||| ||d| jS)NzOProactor event loop requires Python 3.5 or newer (ssl.MemoryBIO) to support SSL)r r!)rZ_is_sslproto_availabler|ZSSLProtocolr}Z_app_transport) rZrawsockrÚ sslcontextrr†r‡r r!Zssl_protocolr#r#r$Ú_make_ssl_transport’s z)BaseProactorEventLoop._make_ssl_transportcCst|||||ƒS)N)r{)rrrrr r#r#r$Ú_make_duplex_pipe_transport sz1BaseProactorEventLoop._make_duplex_pipe_transportcCst|||||ƒS)N)rP)rrrrr r#r#r$Ú_make_read_pipe_transport¥sz/BaseProactorEventLoop._make_read_pipe_transportcCst|||||ƒS)N)ru)rrrrr r#r#r$Ú_make_write_pipe_transport©sz0BaseProactorEventLoop._make_write_pipe_transportcsP|jƒrtdƒ‚|jƒrdS|jƒ|jƒ|jjƒd|_d|_tƒjƒdS)Nz!Cannot close a running event loop) Z is_runningrgÚ is_closedÚ_stop_accept_futuresÚ_close_self_piperXr7rr)r)r"r#r$r7¯s zBaseProactorEventLoop.closecCs|jj||ƒS)N)rXrY)rrÚnr#r#r$Ú sock_recvÁszBaseProactorEventLoop.sock_recvcCs|jj||ƒS)N)rXro)rrr`r#r#r$Úsock_sendallÄsz"BaseProactorEventLoop.sock_sendallcCs|jj||ƒS)N)rXZconnect)rrZaddressr#r#r$Úsock_connectÇsz"BaseProactorEventLoop.sock_connectcCs|jj|ƒS)N)rXÚaccept)rrr#r#r$Úsock_acceptÊsz!BaseProactorEventLoop.sock_acceptcCst‚dS)N)r|)rr#r#r$Ú_socketpairÍsz!BaseProactorEventLoop._socketpaircCsL|jdk r|jjƒd|_|jjƒd|_|jjƒd|_|jd8_dS)Nr)r‚r6Ú_ssockr7Ú_csockÚ _internal_fds)rr#r#r$rÐs z&BaseProactorEventLoop._close_self_pipecCsF|jƒ\|_|_|jjdƒ|jjdƒ|jd7_|j|jƒdS)NFr)r–r—r˜Zsetblockingr™rÚ_loop_self_reading)rr#r#r$r„Ús z%BaseProactorEventLoop._make_self_pipecCs„y$|dk r|jƒ|jj|jdƒ}WnHtjk r:dStk rl}z|jd||dœƒWYdd}~XnX||_|j |j ƒdS)Niz.Error on reading from the event loop self pipe)r?r@r)rWrXrYr—rr]Ú ExceptionrDr‚r^rš)rrqrFr#r#r$ršâsz(BaseProactorEventLoop._loop_self_readingcCs|jjdƒdS)Nó)r˜ro)rr#r#r$Ú_write_to_selfôsz$BaseProactorEventLoop._write_to_selfédcs&d‡‡‡‡‡‡fdd„ ‰ˆjˆƒdS)Ncs"y†|dk rl|jƒ\}}ˆjr,tjdˆ||ƒˆƒ}ˆdk rVˆj||ˆdd|iˆdnˆj||d|iˆdˆjƒrxdSˆjjˆƒ}Wn~t k ræ}zDˆj ƒdkrÀˆjd|ˆdœƒˆjƒnˆjrÖtjd ˆdd WYdd}~Xn8t jk rˆjƒYnX|ˆjˆj ƒ<|jˆƒdS)Nz#%r got a new connection from %r: %rTr~)r†r r!)r r!rzAccept failed on a socket)r?r@rJzAccept failed on socket %r)r>éÿÿÿÿ)rWZ_debugr rCr‰r…rrXr”r\r*rDr7rr]rƒr^)rqZconnZaddrrrF)rÚprotocol_factoryrr!rrˆr#r$rús> z2BaseProactorEventLoop._start_serving..loop)N)r)rr rrˆr!Zbacklogr#)rr rr!rrˆr$Ú_start_serving÷s$z$BaseProactorEventLoop._start_servingcCsdS)Nr#)rZ event_listr#r#r$Ú_process_events sz%BaseProactorEventLoop._process_eventscCs*x|jjƒD]}|jƒqW|jjƒdS)N)rƒÚvaluesr6Úclear)rZfuturer#r#r$rŽ$sz*BaseProactorEventLoop._stop_accept_futurescCs |jƒ|jj|ƒ|jƒdS)N)rŽrXÚ _stop_servingr7)rrr#r#r$r¥)sz#BaseProactorEventLoop._stop_serving)NNN)N)NN)NN)NN)N)NNrž)r(rMrNr r…r‰rŠr‹rŒr7r‘r’r“r•r–rr„ršrr¡r¢rŽr¥rOr#r#)r"r$rs4 ()Ú__all__rJr9Úrrrrrr Úlogr Z_FlowControlMixinZ BaseTransportrZ ReadTransportrPZWriteTransportraruZ Transportr{r}Z BaseEventLooprr#r#r#r$Ús0MT #