آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ 3 \ˆ#م@sگddlZddlZddlZddlmZddlmZddlmZddlmZddl m Z Gdd „d ejƒZGd d„dej ƒZGdd „d eejƒZdS)éNé)عcompat)ع protocols)ع transports)ع coroutine)عloggercsـeZdZd0‡fdd„ Zdd„Zdd„Zdd „Zd d„Zdd „Zdd„Z e jrTdd„Zdd„Z dd„Zdd„Zdd„Zdd„Zdd„Zdd„Zed d!„ƒZd"d#„Zd$d%„Zd&d'„Zd(d)„Zed*d+„ƒZd,d-„Zd.d/„Z‡ZS)1عBaseSubprocessTransportNc s&tƒj| ƒd|_||_||_d|_d|_d|_g|_t j ƒ|_i|_d|_ |tjkr`d|jd<|tjkrtd|jd<|tjkrˆd|jd<y"|jf||||||dœ|—ژWn|jƒ‚YnX|jj|_|j|jd<|jjƒگrt|ttfƒrّ|}n|d}tjd||jƒ|jj|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عprotocolr rrr rrعwaiterZextraعkwargsZprogram)ع __class__©ْ//usr/lib64/python3.6/asyncio/base_subprocess.pyrs@ z BaseSubprocessTransport.__init__cCs|jjg}|jr|jdƒ|jdk r4|jd|jƒ|jdk rP|jd|jƒn |jdk rf|jdƒn |jdƒ|jjdƒ}|dk r”|jd|jƒ|jjdƒ}|jjd ƒ}|dk rخ||krخ|jd |jƒn0|dk rو|jd|jƒ|dk r‏|jd|jƒd dj |ƒS)Nعclosedzpid=%sz returncode=%sZrunningznot startedrzstdin=%srr zstdout=stderr=%sz stdout=%sz stderr=%sz<%s>ْ ) r.ع__name__rعappendrrrعgetعpipeعjoin)r)عinforr rr/r/r0ع__repr__9s, z BaseSubprocessTransport.__repr__cKst‚dS)N)عNotImplementedError)r)r rrr rrr-r/r/r0r VszBaseSubprocessTransport._startcCs ||_dS)N)r)r)r+r/r/r0عset_protocolYsz$BaseSubprocessTransport.set_protocolcCs|jS)N)r)r)r/r/r0عget_protocol\sz$BaseSubprocessTransport.get_protocolcCs|jS)N)r)r)r/r/r0ع is_closing_sz"BaseSubprocessTransport.is_closingcCsک|jr dSd|_x&|jjƒD]}|dkr*q|jjƒqW|jdk r”|jdkr”|jjƒdkr”|jj ƒrpt jd|ƒy|jjƒWnt k r’YnXdS)NTz$Close running child process: kill %r)rrعvaluesr6r!rrZpollrr#rZwarningعkillعProcessLookupError)r)عprotor/r/r0r!bs zBaseSubprocessTransport.closecCs&|js"tjd|t|dچ|jƒdS)Nzunclosed transport %r)عsource)rعwarningsعwarnعResourceWarningr!)r)r/r/r0ع__del__€szBaseSubprocessTransport.__del__cCs|jS)N)r)r)r/r/r0عget_pid†szBaseSubprocessTransport.get_pidcCs|jS)N)r)r)r/r/r0عget_returncode‰sz&BaseSubprocessTransport.get_returncodecCs||jkr|j|jSdSdS)N)rr6)r)عfdr/r/r0عget_pipe_transportŒs z*BaseSubprocessTransport.get_pipe_transportcCs|jdkrtƒ‚dS)N)rr@)r)r/r/r0ع_check_proc’s z#BaseSubprocessTransport._check_proccCs|jƒ|jj|ƒdS)N)rKrعsend_signal)r)عsignalr/r/r0rL–sz#BaseSubprocessTransport.send_signalcCs|jƒ|jjƒdS)N)rKrع terminate)r)r/r/r0rNڑsz!BaseSubprocessTransport.terminatecCs|jƒ|jjƒdS)N)rKrr?)r)r/r/r0r?‍szBaseSubprocessTransport.killc #sPyوˆj}ˆj}|jdk rB|j‡fdd„|jƒEdH\}}|ˆjd<|jdk rv|j‡fdd„|jƒEdH\}}|ˆjd<|jdk rھ|j‡fdd„|jƒEdH\}}|ˆjd<|jˆj j ˆƒx"ˆjD]\}}|j|f|‍ژqآWdˆ_WnDtk گr*}z&|dk گr|j ƒگr|j|ƒWYdd}~Xn"X|dk گrL|j ƒگrL|jdƒdS)Ncs tˆdƒS)Nr)عWriteSubprocessPipeProtor/)r)r/r0عھsz8BaseSubprocessTransport._connect_pipes..rcs tˆdƒS)Nr)عReadSubprocessPipeProtor/)r)r/r0rP°srcs tˆdƒS)Nr )rQr/)r)r/r0rP¶sr )rrrZconnect_write_piperr Zconnect_read_piperع call_soonrعconnection_maderع Exceptionع cancelledZ set_exceptionع set_result) r)r,عprocr*ع_r6عcallbackعdataعexcr/)r)r0r(¢s6 z&BaseSubprocessTransport._connect_pipescGs2|jdk r|jj||fƒn|jj|f|‍ژdS)N)rr4rrR)r)عcbrZr/r/r0ع_callاs zBaseSubprocessTransport._callcCs|j|jj||ƒ|jƒdS)N)r]rZpipe_connection_lostع_try_finish)r)rIr[r/r/r0ع_pipe_connection_lostحsz-BaseSubprocessTransport._pipe_connection_lostcCs|j|jj||ƒdS)N)r]rZpipe_data_received)r)rIrZr/r/r0ع_pipe_data_receivedرsz+BaseSubprocessTransport._pipe_data_receivedcCst|jjƒrtjd||ƒ||_|jjdkr2||j_|j|jj ƒ|j ƒx |jD]}|jƒsP|j |ƒqPWd|_dS)Nz%r exited with return code %r)rr#rr8rrع returncoder]rZprocess_exitedr^rrUrV)r)rar,r/r/r0ع_process_exitedشs z'BaseSubprocessTransport._process_exitedccs0|jdk r|jS|jjƒ}|jj|ƒ|EdHS)zdWait until the process exit and return the process return code. This method is a coroutine.N)rrZ create_futurerr4)r)r,r/r/r0ع_waitès zBaseSubprocessTransport._waitcCs>|jdkrdStdd„|jjƒDƒƒr:d|_|j|jdƒdS)Ncss|]}|dk o|jVqdS)N)عdisconnected)ع.0عpr/r/r0ْ ّsz6BaseSubprocessTransport._try_finish..T)rعallrr>rr]ع_call_connection_lost)r)r/r/r0r^ôs z#BaseSubprocessTransport._try_finishcCs*z|jj|ƒWdd|_d|_d|_XdS)N)rعconnection_lostrr)r)r[r/r/r0ri‎s z-BaseSubprocessTransport._call_connection_lost)NN)r3ع __module__ع__qualname__rr9r r;r<r=r!rZPY34rFrGrHrJrKrLrNr?rr(r]r_r`rbrcr^riع __classcell__r/r/)r.r0rs0)% rc@s<eZdZdd„Zdd„Zdd„Zdd„Zd d „Zdd„Zd S)rOcCs||_||_d|_d|_dS)NF)rWrIr6rd)r)rWrIr/r/r0rsz!WriteSubprocessPipeProto.__init__cCs ||_dS)N)r6)r)Z transportr/r/r0rSsz(WriteSubprocessPipeProto.connection_madecCsd|jj|j|jfS)Nz<%s fd=%s pipe=%r>)r.r3rIr6)r)r/r/r0r9sz!WriteSubprocessPipeProto.__repr__cCs d|_|jj|j|ƒd|_dS)NT)rdrWr_rI)r)r[r/r/r0rjsz(WriteSubprocessPipeProto.connection_lostcCs|jjjƒdS)N)rWrع pause_writing)r)r/r/r0rnsz&WriteSubprocessPipeProto.pause_writingcCs|jjjƒdS)N)rWrعresume_writing)r)r/r/r0rosz'WriteSubprocessPipeProto.resume_writingN) r3rkrlrrSr9rjrnror/r/r/r0rOsrOc@seZdZdd„ZdS)rQcCs|jj|j|ƒdS)N)rWr`rI)r)rZr/r/r0ع data_received$sz%ReadSubprocessPipeProto.data_receivedN)r3rkrlrpr/r/r/r0rQ!srQ)rrrCعrrrZ coroutinesrعlogrZSubprocessTransportrZBaseProtocolrOZProtocolrQr/r/r/r0عs{