آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ U ،ê,a‹"م@sxddlZddlZddlZddlmZddlmZddlmZGdd„dejƒZ Gdd „d ej ƒZGd d„deejƒZ dS)éNé)ع protocols)ع transports)عloggercsشeZdZd0‡fdd„ Zdd„Zdd„Zdd „Zd d„Zdd „Zdd„Z e jfdd„Zdd„Z dd„Zdd„Zdd„Zdd„Zdd„Zdd„Zd d!„Zd"d#„Zd$d%„Zd&d'„Zd(d)„Zd*d+„Zd,d-„Zd.d/„Z‡ZS)1عBaseSubprocessTransportNc s&tƒ | ،d|_||_||_d|_d|_d|_g|_t ،|_i|_d|_ |tjkr`d|jd<|tjkrtd|jd<|tjkrˆd|jd<z"|jf||||||dœ|—ژWn| ،‚YnX|jj|_|j|jd<|j ،گrt|ttfƒrّ|}n|d}t d||j،|j | | ،،dS)NFrré)عargsعshellعstdinعstdoutعstderrعbufsizeع subprocesszprocess %r created: pid %s)عsuperع__init__ع_closedع _protocolع_loopع_procع_pidع_returncodeع _exit_waitersعcollectionsعdequeع_pending_callsع_pipesع _finishedrعPIPEع_startعcloseعpidZ_extraع get_debugع isinstanceعbytesعstrrعdebugZcreate_taskع_connect_pipes) عselfعloopعprotocolrr r rrr عwaiterZextraعkwargsZprogram©ع __class__©ْْ )r-ع__name__rعappendrrrعgetعpipeعformatعjoin)r'عinfor rrr.r.r/ع__repr__7s, z BaseSubprocessTransport.__repr__cKst‚dS©N)عNotImplementedError)r'rr r rrr r+r.r.r/rTszBaseSubprocessTransport._startcCs ||_dSr:©r)r'r)r.r.r/عset_protocolWsz$BaseSubprocessTransport.set_protocolcCs|jSr:r<©r'r.r.r/عget_protocolZsz$BaseSubprocessTransport.get_protocolcCs|jSr:)rr>r.r.r/ع is_closing]sz"BaseSubprocessTransport.is_closingcCs”|jr dSd|_|j ،D]}|dkr(q|j ،q|jdk rگ|jdkrگ|j ،dkrگ|j ،rlt d|،z|j ،Wnt k rژYnXdS)NTz$Close running child process: kill %r)rrعvaluesr5rrrZpollrr!rZwarningعkillعProcessLookupError)r'عprotor.r.r/r`s$ ‏û zBaseSubprocessTransport.closecCs&|js"|d|›‌t|dچ| ،dS)Nzunclosed transport )عsource)rعResourceWarningr)r'Z_warnr.r.r/ع__del__{szBaseSubprocessTransport.__del__cCs|jSr:)rr>r.r.r/عget_pid€szBaseSubprocessTransport.get_pidcCs|jSr:)rr>r.r.r/عget_returncodeƒsz&BaseSubprocessTransport.get_returncodecCs||jkr|j|jSdSdSr:)rr5)r'عfdr.r.r/عget_pipe_transport†s z*BaseSubprocessTransport.get_pipe_transportcCs|jdkrtƒ‚dSr:)rrCr>r.r.r/ع_check_procŒs z#BaseSubprocessTransport._check_proccCs| ،|j |،dSr:)rLrعsend_signal)r'عsignalr.r.r/rMگsz#BaseSubprocessTransport.send_signalcCs| ،|j ،dSr:)rLrع terminater>r.r.r/rO”sz!BaseSubprocessTransport.terminatecCs| ،|j ،dSr:)rLrrBr>r.r.r/rBکszBaseSubprocessTransport.killc ƒs`zâˆj}ˆj}|jdk rB| ‡fdd„|j،IdH\}}|ˆjd<|jdk rv| ‡fdd„|j،IdH\}}|ˆjd<|jdk rھ| ‡fdd„|j،IdH\}}|ˆjd<| ˆj j ˆ،ˆjD]\}}|j|f|‍ژqہdˆ_WnZtt fk rü‚Yn`tk گr<}z"|dk گr,| ،گs,| |،W5d}~XYn X|dk گr\| ،گs\| d،dS)Ncs tˆdƒS)Nr)عWriteSubprocessPipeProtor.r>r.r/ع£َz8BaseSubprocessTransport._connect_pipes..rcs tˆdƒS)Nr©عReadSubprocessPipeProtor.r>r.r/rQ©rRrcs tˆdƒS)NrrSr.r>r.r/rQ¯rRr)rrr Zconnect_write_piperrZconnect_read_piperع call_soonrعconnection_maderع SystemExitعKeyboardInterruptع BaseExceptionع cancelledZ set_exceptionع set_result) r'r*عprocr(ع_r5عcallbackعdataعexcr.r>r/r&œs@ ‏ ‏ ‏ z&BaseSubprocessTransport._connect_pipescGs2|jdk r|j ||f،n|jj|f|‍ژdSr:)rr3rrU)r'عcbr_r.r.r/ع_callآs zBaseSubprocessTransport._callcCs| |jj||،| ،dSr:)rbrZpipe_connection_lostع_try_finish)r'rJr`r.r.r/ع_pipe_connection_lostبsz-BaseSubprocessTransport._pipe_connection_lostcCs| |jj||،dSr:)rbrZpipe_data_received)r'rJr_r.r.r/ع_pipe_data_receivedجsz+BaseSubprocessTransport._pipe_data_receivedcCsp|j ،rt d||،||_|jjdkr2||j_| |jj ،| ،|jD]}| ،sN| |،qNd|_dS)Nz%r exited with return code %r)rr!rr8rrع returncoderbrZprocess_exitedrcrrZr[)r'rfr*r.r.r/ع_process_exitedدs z'BaseSubprocessTransport._process_exitedcأs0|jdk r|jS|j ،}|j |،|IdHS)zdWait until the process exit and return the process return code. This method is a coroutine.N)rrZ create_futurerr3)r'r*r.r.r/ع_waitâs zBaseSubprocessTransport._waitcCs>|jdkrdStdd„|j ،Dƒƒr:d|_| |jd،dS)Ncss|]}|dk o|jVqdSr:)عdisconnected)ع.0عpr.r.r/ع ٌsےz6BaseSubprocessTransport._try_finish..T)rعallrrArrbع_call_connection_lostr>r.r.r/rcيs ےz#BaseSubprocessTransport._try_finishcCs*z|j |،W5d|_d|_d|_XdSr:)rrrعconnection_lost©r'r`r.r.r/rnِs z-BaseSubprocessTransport._call_connection_lost)NN)r2ع __module__ع__qualname__rr9rr=r?r@rعwarningsعwarnrGrHrIrKrLrMrOrBr&rbrdrergrhrcrnع __classcell__r.r.r,r/r s2‏+& rc@s<eZdZdd„Zdd„Zdd„Zdd„Zd d „Zdd„Zd S)rPcCs||_||_d|_d|_dS)NF)r\rJr5ri)r'r\rJr.r.r/rsz!WriteSubprocessPipeProto.__init__cCs ||_dSr:)r5)r'Z transportr.r.r/rVsz(WriteSubprocessPipeProto.connection_madecCs d|jj›d|j›d|j›d‌S)Nْ)r-r2rJr5r>r.r.r/r9 sz!WriteSubprocessPipeProto.__repr__cCs d|_|j |j|،d|_dS)NT)rir\rdrJrpr.r.r/ro sz(WriteSubprocessPipeProto.connection_lostcCs|jj ،dSr:)r\rع pause_writingr>r.r.r/rxsz&WriteSubprocessPipeProto.pause_writingcCs|jj ،dSr:)r\rعresume_writingr>r.r.r/rysz'WriteSubprocessPipeProto.resume_writingN) r2rqrrrrVr9rorxryr.r.r.r/rPےsrPc@seZdZdd„ZdS)rTcCs|j |j|،dSr:)r\rerJ)r'r_r.r.r/ع data_receivedsz%ReadSubprocessPipeProto.data_receivedN)r2rqrrrzr.r.r.r/rTsrT)rrrsعrrعlogrZSubprocessTransportrZBaseProtocolrPZProtocolrTr.r.r.r/عsvے