яПН !A?hяПНяПНяПНяПНdZddlZddlmZddlmZddlmZddlmZddlmZej Z ej Z ejZGd яПНd ejej яПНяПНZGdяПНdяПНяПНZdddejfd яПНZdddejdяПНdяПНZdS))яПНcreate_subprocess_execяПНcreate_subprocess_shellяПНNяПН)яПНevents)яПН protocols)яПНstreams)яПНtasks)яПНloggercяПНLяПНяПНeZdZdZяПНfdяПНZdяПНZdяПНZdяПНZdяПНZdяПНZ dяПНZ d яПНZяПНxZS) яПНSubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.cяПНяПНяПНяПНtяПНяПНяПН|яПНяПНяПН||_dx|_x|_|_d|_d|_g|_|j яПН яПНяПН|_dS)N)яПНloopF)яПНsuperяПН__init__яПН_limitяПНstdinяПНstdoutяПНstderrяПН _transportяПН_process_exitedяПН _pipe_fdsяПН_loopяПН create_futureяПН _stdin_closed)яПНselfяПНlimitrяПН __class__s яПНяПН?/opt/alt/python-internal/lib64/python3.11/asyncio/subprocess.pyrz!SubprocessStreamProtocol.__init__slяПНяПНяПН яПНяПНяПНяПНяПНdяПНяПН#яПН#яПН#яПНяПНяПНяПН15яПН5яПНяПН яПН5яПНTяПН[яПН4яПН;яПНяПНяПНяПН$яПНяПНяПНяПНяПНяПН!яПНZяПН5яПН5яПН7яПН7яПНяПНяПНяПНяПНcяПНDяПН|jjg}|jяПН|яПНd|jяПНяПНяПНяПН|jяПН|яПНd|jяПНяПНяПНяПН|jяПН|яПНd|jяПНяПНяПНяПНdяПНdяПН|яПНяПНяПНяПНS)Nzstdin=zstdout=zstderr=z<{}>яПН )rяПН__name__rяПНappendrrяПНformatяПНjoin)rяПНinfos rяПН__repr__z!SubprocessStreamProtocol.__repr__sяПНяПНяПНяПНяПН'яПН(яПНяПНяПН:яПН!яПНяПНKяПНKяПН/яПНяПНяПН/яПН/яПН0яПН0яПН0яПНяПН;яПН"яПНяПНKяПНKяПН1яПН$яПН+яПН1яПН1яПН2яПН2яПН2яПНяПН;яПН"яПНяПНKяПНKяПН1яПН$яПН+яПН1яПН1яПН2яПН2яПН2яПНяПН}яПН}яПНSяПНXяПНXяПНdяПН^яПН^яПН,яПН,яПН,rcяПНJяПН||_|яПНdяПНяПН}|яПНYtj|j|jяПНяПНяПН|_|jяПН|яПНяПН|jяПН dяПНяПН|яПНdяПНяПН}|яПНYtj|j|jяПНяПНяПН|_ |j яПН|яПНяПН|jяПН dяПНяПН|яПНdяПНяПН}|яПН$tj||d|jяПНяПНяПН|_dSdS)NrяПНrrяПНr)яПНprotocolяПНreaderr) rяПНget_pipe_transportrяПНStreamReaderrrrяПН set_transportrr#rяПНStreamWriterr)rяПН transportяПНstdout_transportяПНstderr_transportяПНstdin_transports rяПНconnection_madez(SubprocessStreamProtocol.connection_made(s,яПНяПН#яПНяПНяПН$яПН7яПН7яПНяПН:яПН:яПНяПНяПН'яПН!яПН.яПНTяПН[яПН48яПНJяПН@яПН@яПН@яПНDяПНKяПНяПНKяПН%яПН%яПН&6яПН7яПН7яПН7яПНяПНNяПН!яПН!яПН!яПН$яПН$яПН$яПН$яПН7яПН7яПНяПН:яПН:яПНяПНяПН'яПН!яПН.яПНTяПН[яПН48яПНJяПН@яПН@яПН@яПНDяПНKяПНяПНKяПН%яПН%яПН&6яПН7яПН7яПН7яПНяПНNяПН!яПН!яПН!яПН$яПН$яПН$яПН#яПН6яПН6яПНqяПН9яПН9яПНяПНяПН&яПН яПН-яПНoяПН7;яПН59яПН37яПН:яПН?яПН?яПН?яПНDяПНJяПНJяПНJяПН'яПН&rcяПНtяПН|dkr|j}n|dkr|j}nd}|яПН|яПН|яПНяПНdSdSяПНNrr*)rrяПН feed_data)rяПНfdяПНdatar,s rяПНpipe_data_receivedz+SubprocessStreamProtocol.pipe_data_received@sSяПНяПН яПНяПН7яПН7яПНяПН[яПНFяПНFяПН яПН1яПНWяПНWяПНяПН[яПНFяПНFяПНяПНFяПНяПНяПНяПНяПНяПНTяПН"яПН"яПН"яПН"яПН"яПНяПНrcяПНяПН|dkrw|j}|яПН|яПНяПНяПН|яПН|яПНяПН|яПН|jяПНdяПНяПНn&|jяПН|яПНяПНd|j_dS|dkr|j}n|dkr|j}nd}|яПН,|яПН|яПН яПНяПНn|яПН|яПНяПН||j vr|j яПН|яПНяПН|яПНяПНяПНdS)NrFrr*) rяПНcloseяПНconnection_lostrяПН set_resultяПН set_exceptionяПН_log_tracebackrrяПНfeed_eofrяПНremoveяПН_maybe_close_transport)rr9яПНexcяПНpiper,s rяПНpipe_connection_lostz-SubprocessStreamProtocol.pipe_connection_lostJsяПНяПН яПНяПН7яПН7яПНяПН:яПНDяПНяПНяПНяПН яПН яПНяПНяПНяПНяПН яПН яПНяПН%яПН%яПН%яПНяПН{яПНяПН"яПН-яПН-яПНdяПН3яПН3яПН3яПН3яПНяПН"яПН0яПН0яПНяПН5яПН5яПН5яПН5:яПНяПН"яПН1яПНяПНFяПН яПНяПН7яПН7яПНяПН[яПНFяПНFяПН яПН1яПНWяПНWяПНяПН[яПНFяПНFяПНяПНFяПНяПНяПНяПН{яПНяПНяПНяПН!яПН!яПН!яПН!яПНяПН$яПН$яПНSяПН)яПН)яПН)яПН яПНяПНяПНяПНяПНяПНNяПН!яПН!яПН"яПН%яПН%яПН%яПНяПН#яПН#яПН%яПН%яПН%яПН%яПН%rcяПН<яПНd|_|яПНяПНяПНdS)NT)rrDяПНrs rяПНprocess_exitedz'SubprocessStreamProtocol.process_exitedhs"яПНяПН#яПНяПНяПНяПН#яПН#яПН%яПН%яПН%яПН%яПН%rcяПНяПНt|jяПНяПНdkr)|jr$|jяПНяПНяПНd|_dSdSdS)Nr)яПНlenrrrr=rIs rrDz/SubprocessStreamProtocol._maybe_close_transportlsLяПНяПНяПНtяПН~яПНяПНяПН!яПН#яПН#яПНяПН(<яПН#яПНяПНOяПН!яПН!яПН#яПН#яПН#яПН"яПНDяПНOяПНOяПНOяПН$яПН#яПН#яПН#rcяПН&яПН||jur|jSdSяПНN)rr)rяПНstreams rяПН_get_close_waiterz*SubprocessStreamProtocol._get_close_waiterqs яПНяПНяПНTяПНZяПНяПНяПНяПН%яПН%яПН яПНr) r"яПН __module__яПН__qualname__яПН__doc__rr'r5r;rGrJrDrPяПН __classcell__)rs@rrrsяПНяПНяПНяПНяПНяПНяПНяПН:яПН:яПН8яПН8яПН8яПН8яПН8яПН-яПН-яПН-яПН?яПН?яПН?яПН0#яПН#яПН#яПН&яПН&яПН&яПН<&яПН&яПН&яПН#яПН#яПН#яПН &яПН&яПН&яПН&яПН&яПН&яПН&rrcяПНbяПНeZdZdяПНZdяПНZedяПНяПНяПНZdяПНZdяПНZdяПНZ dяПНZ dяПНZd яПНZd яПНZ d dяПНZdS)яПНProcesscяПНяПН||_||_||_|j|_|j|_|j|_|яПНяПНяПН|_dSrN)rяПН _protocolrrrrяПНget_pidяПНpid)rr1r+rs rrzProcess.__init__wsIяПНяПН#яПНяПНяПН!яПНяПНяПНяПНяПН яПНяПН^яПНяПН яПНяПНoяПНяПНяПНяПНoяПНяПНяПНяПН$яПН$яПН&яПН&яПНяПНяПНяПНrcяПН2яПНd|jjяПНd|jяПНdяПНS)NяПН)rr"rZrIs rr'zProcess.__repr__яПНs"яПНяПН8яПН4яПН>яПН*яПН8яПН8яПНTяПНXяПН8яПН8яПН8яПН8rcяПН4яПН|jяПНяПНяПНSrN)rяПНget_returncoderIs rяПН returncodezProcess.returncodeяПНsяПНяПНяПНяПН-яПН-яПН/яПН/яПН/rcяПНяПНDKяПН|jяПНяПНяПНяПНd{VяПНяПНS)z?Wait until the process exit and return the process return code.N)rяПН_waitrIs rяПНwaitzProcess.waitяПНs,яПНяПНяПНяПНяПН_яПН*яПН*яПН,яПН,яПН,яПН,яПН,яПН,яПН,яПН,яПН,rcяПН:яПН|jяПН|яПНяПНdSrN)rяПНsend_signal)rяПНsignals rrezProcess.send_signalяПНsяПНяПНяПНяПН#яПН#яПНFяПН+яПН+яПН+яПН+яПН+rcяПН8яПН|jяПНяПНяПНdSrN)rяПН terminaterIs rrhzProcess.terminateяПНsяПНяПНяПНяПН!яПН!яПН#яПН#яПН#яПН#яПН#rcяПН8яПН|jяПНяПНяПНdSrN)rяПНkillrIs rrjzProcess.killяПНsяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНrcяПНяПНяПНKяПН|jяПНяПНяПН} |jяПН|яПНяПН|r#t jd|t |яПНяПНяПНяПН|jяПНяПНяПНяПНd{VяПНяПНn6#ttf$r"}|rt jd||яПНяПНYd}~nd}~wwxYw|rt jd|яПНяПН|jяПН яПНяПНdS)Nz%%r communicate: feed stdin (%s bytes)z%r communicate: stdin got %rz%r communicate: close stdin)rяПН get_debugrяПНwriter яПНdebugrLяПНdrainяПНBrokenPipeErrorяПНConnectionResetErrorr=)rяПНinputrnrEs rяПН_feed_stdinzProcess._feed_stdinяПНsяПНяПНяПНяПНяПН яПН$яПН$яПН&яПН&яПНяПН HяПНяПНJяПНяПНяПНUяПН#яПН#яПН#яПНяПН OяПНяПНяПН;яПНTяПН3яПНuяПН:яПН:яПНOяПНOяПНOяПНяПН*яПН"яПН"яПН$яПН$яПН$яПН$яПН$яПН$яПН$яПН$яПН$яПН$яПНяПНяПН!5яПН6яПН HяПН HяПН HяПНяПН HяПНяПНяПН;яПНTяПН3яПНGяПНGяПНGяПНяПНяПНяПНяПНяПНяПНяПНяПНяПН HяПНяПНяПНяПНяПН >яПНяПНLяПН6яПНяПН=яПН=яПН=яПНяПН яПНяПНяПНяПНяПНяПНяПНsяПНAA<яПН<B/яПН B*яПН*B/cяПНяПН KяПНdSrNяПНrIs rяПН_noopz Process._noopяПНsяПНяПНяПНяПНяПНtrcяПНяПНKяПН|jяПН|яПНяПН}|dkr|j}n|dksJяПН|j}|jяПНяПНяПНr |dkrdnd}t jd||яПНяПН|яПНяПНяПНяПНd{VяПНяПН}|jяПНяПНяПНr |dkrdnd}t jd||яПНяПН|яПН яПНяПН|S)Nr*rrrz%r communicate: read %sz%r communicate: close %s) rr-rrrrlr rnяПНreadr=)rr9r1rOяПНnameяПНoutputs rяПН_read_streamzProcess._read_streamяПНsяПНяПНяПНяПНяПНяПНOяПН6яПН6яПНrяПН:яПН:яПН яПН яПНяПН7яПН7яПНяПН[яПНFяПНFяПНяПНяПН7яПН7яПН7яПН7яПНяПН[яПНFяПНяПН:яПНяПНяПН!яПН!яПН @яПН!яПНQяПНwяПНwяПН8яПН8яПНHяПНDяПНяПНLяПН2яПНDяПН$яПН?яПН?яПН?яПНяПН{яПН{яПН}яПН}яПН$яПН$яПН$яПН$яПН$яПН$яПНяПНяПН:яПНяПНяПН!яПН!яПН AяПН!яПНQяПНwяПНwяПН8яПН8яПНHяПНDяПНяПНLяПН3яПНTяПН4яПН@яПН@яПН@яПНяПНяПНяПНяПНяПНяПНяПН rNcяПНяПНKяПН|яПН|яПН|яПНяПН}n|яПНяПНяПН}|jяПН|яПНdяПНяПН}n|яПНяПНяПН}|jяПН|яПНdяПНяПН}n|яПНяПНяПН}tj|||яПНяПНяПНd{VяПНяПН\}}}|яПНяПНяПНяПНd{VяПНяПН||fSr7)rsrvrr{rr яПНgatherrc)rrrrrrs rяПНcommunicatezProcess.communicateяПНsяПНяПНяПНяПНяПНяПНяПНяПН$яПН$яПНUяПН+яПН+яПНEяПНEяПНяПНJяПНJяПНLяПНLяПНEяПНяПН;яПН"яПНяПН&яПН&яПНqяПН)яПН)яПНFяПНFяПНяПНZяПНZяПН\яПН\яПНFяПНяПН;яПН"яПНяПН&яПН&яПНqяПН)яПН)яПНFяПНFяПНяПНZяПНZяПН\яПН\яПНFяПН&+яПНlяПН5яПН&яПН&яПН&IяПН&IяПН IяПН IяПН IяПН IяПН IяПН IяПНяПНяПНvяПНvяПНяПНiяПНiяПНkяПНkяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНrrN)r"rQrRrr'яПНpropertyr`rcrerhrjrsrvr{r~rurrrVrVvsяПНяПНяПНяПНяПНяПНяПН'яПН'яПН'яПН9яПН9яПН9яПНяПН0яПН0яПНяПНXяПН0яПН-яПН-яПН-яПН,яПН,яПН,яПН$яПН$яПН$яПНяПНяПНяПНяПНяПНяПН&яПНяПНяПНяПНяПНяПН" яПН яПН яПН яПН яПН rrVcяПНяПНяПНяПН KяПНtjяПНяПНяПН яПНяПН fdяПН}яПН j||f|||dяПН|яПНяПНяПНd{VяПНяПН\}}t||яПН яПНяПНS)NcяПН&яПНяПНtяПНяПНяПНяПНяПНSяПНNr)яПНrr)sяПНяПНrяПНz)create_subprocess_shell..яПНяПНяПНяПНяПН7яПНeяПН=AяПН CяПН CяПН CяПНrяПНrrr)rяПНget_running_loopяПНsubprocess_shellrV) яПНcmdrrrrяПНkwdsяПНprotocol_factoryr1r+rs ` @rrrяПНsяПНяПНяПНяПНяПНяПНяПНяПН"яПН$яПН$яПНDяПНCяПНCяПНCяПНCяПНCяПНяПН 5яПНяПН 5яПНяПНяПН!яПНяПНяПНяПН!яПН!яПНяПН!яПН!яПНяПНяПНяПНяПНяПНяПНяПНIяПНxяПНяПН9яПНhяПНяПН-яПН-яПН-r)rrrrcяПНяПНяПНяПН KяПНtjяПНяПНяПН яПНяПН fdяПН}яПН j||g|яПНR|||dяПН|яПНяПНяПНd{VяПНяПН\}} t|| яПН яПНяПНS)NcяПН&яПНяПНtяПНяПНяПНяПНяПНSrяПНrяПНr)sяПНяПНrrяПНz(create_subprocess_exec..яПНrяПНrrяПН)rrяПНяПНsubprocess_execrV)яПНprogramrrrrяПНargsrяПНrяПНr1r+rs ` @rrrяПНsяПНяПНяПНяПНяПНяПНяПНяПН"яПН$яПН$яПНDяПНCяПНCяПНCяПНCяПНCяПНяПН 4яПНяПН 4яПНяПНяПН!яПНяПН!яПН!яПНяПНFяПНяПН !яПН!яПНяПН !яПН!яПНяПНяПНяПНяПНяПНяПНяПНIяПНxяПН яПН9яПНhяПНяПН-яПН-яПН-r)яПН__all__яПН subprocessяПНrrrr яПНlogr яПНPIPEяПНSTDOUTяПНDEVNULLяПНFlowControlMixinяПНSubprocessProtocolrrVяПН_DEFAULT_LIMITrrrurrяПНrяПНsKяПНяПН =яПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПНяПН яПН яПНяПН яПН яПНяПНb&яПНb&яПНb&яПНb&яПНb&яПНwяПН7яПН(яПН;яПНb&яПНb&яПНb&яПНJT яПНT яПНT яПНT яПНT яПНT яПНT яПНT яПНn.2яПН$яПНtяПН(/яПН(>яПН .яПН .яПН .яПН .яПН8<яПНDяПН(,яПНGяПН4JяПН.яПН.яПН.яПН.яПН.яПН.яПН.r