5-SSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSK J r "SS\R5r "SS \R5r"S S \\R5rg) N) protocols) transports)loggerc^\rSrSrSU4SjjrSrSrSrSrSr Sr \ R4S jr S rS rS rS r\R&S:Xa SrSrSrO SrSrSrSrSrSrSrSrSrSrSrSrU=r $)BaseSubprocessTransport c >[T U]U 5 SUlX lXlSUlSUlSUl/Ul[R"5Ul 0Ul SUl U[R:XaSURS'U[R:XaSURS'U[R:XaSURS'UR "SX4XVXxS.U D6 UR R$UlUR UR&S'URR)5(aD[+U[,[.45(aUn OUSn [0R2"SXR 5 URR5UR7U 55 g! UR#5 e=f) NFrr)argsshellstdinstdoutstderrbufsize subprocesszprocess %r created: pid %s)super__init___closed _protocol_loop_proc_pid _returncode _exit_waiters collectionsdeque_pending_calls_pipes _finishedrPIPE_startclosepid_extra get_debug isinstancebytesstrrdebug create_task_connect_pipes)selfloopprotocolr r rrrrwaiterextrakwargsprogram __class__s >/opt/alt/python313/lib64/python3.13/asyncio/base_subprocess.pyr BaseSubprocessTransport.__init__sp  !   )//1  JOO #!DKKN Z__ $!DKKN Z__ $!DKKN  KK BTe% B:@ B JJNN $(JJ L! ::   ! !$ --q' LL5 )) - t226:;  JJL s F**F=cvURR/nUR(aURS5 URbURSUR35 UR bURSUR 35 O0URbURS5 OURS5 UR RS5nUbURSUR35 UR RS5nUR RS 5nUb#XCLaURS UR35 OBUbURS UR35 UbURS UR35 S RSRU55$)Nclosedzpid=z returncode=runningz not startedrzstdin=rr zstdout=stderr=zstdout=zstderr=z<{}> ) r5__name__rappendrrr getpipeformatjoin)r.inforrrs r6__repr__ BaseSubprocessTransport.__repr__:sV''( << KK ! 99 KK$tyyk* +    ' KK+d&6&6%78 9 YY " KK " KK & "   KK& - .##  &"2 KK. 6 7! gfkk]34! gfkk]34}}SXXd^,,c [eN)NotImplementedError)r.r r rrrrr3s r6r#BaseSubprocessTransport._startWs!!rEcXlgrGr)r.r0s r6 set_protocol$BaseSubprocessTransport.set_protocolZs!rEcUR$rGrKr.s r6 get_protocol$BaseSubprocessTransport.get_protocol]s ~~rEcUR$rG)rrOs r6 is_closing"BaseSubprocessTransport.is_closing`s ||rEc\UR(agSUlURR5HVnUcMUR(dMURR 5(aM<UR R 5 MX URb|URcnURR5cRURR5(a[R"SU5 URR5 gggg![[4a gf=f)NTz$Close running child process: kill %r)rr valuesr is_closedr?r$rrpollr'rwarningkillProcessLookupErrorPermissionError)r.protos r6r$BaseSubprocessTransport.closecs <<  [['')E} zzz$**"6"6"8"8   "* JJ "  ( !)zz##%%EtL  ! *) #'8  s:DD+*D+chUR(d!U"SU<3[US9 UR5 gg)Nzunclosed transport )source)rResourceWarningr$)r._warns r6__del__BaseSubprocessTransport.__del__s+|| 'x0/$ O JJLrEcUR$rG)rrOs r6get_pidBaseSubprocessTransport.get_pids yyrEcUR$rG)rrOs r6get_returncode&BaseSubprocessTransport.get_returncodesrEcTXR;aURUR$grG)r r?)r.fds r6get_pipe_transport*BaseSubprocessTransport.get_pipe_transports#  ;;r?'' 'rEc2URc [5egrG)rr[rOs r6 _check_proc#BaseSubprocessTransport._check_procs :: $& & rEwin32cZUR5 URRU5 grG)rpr send_signalr.signals r6rt#BaseSubprocessTransport.send_signals     JJ " "6 *rEcXUR5 URR5 grG)rpr terminaterOs r6ry!BaseSubprocessTransport.terminates     JJ "rEcXUR5 URR5 grG)rprrZrOs r6rZBaseSubprocessTransport.kills     JJOO rEcUR5 [R"URRU5 g![ a gf=frG)rposrZrr%r[rus r6rtrws;      /%  s+> A  A cBUR[R5 grG)rtrvSIGTERMrOs r6ryrz   V^^ ,rEcBUR[R5 grG)rtrvSIGKILLrOs r6rZr|rrEc^# TRnTRnURb9URU4SjUR5IShvN upEUTRS'UR b9UR U4SjUR 5IShvN upEUTRS'URb9UR U4SjUR5IShvN upEUTRS'URTRRT5 TRHupgUR"U/UQ76 M STl Ub(UR5(dURS5 gggGN#NN![[4a e[ a=nUb0UR5(dUR#U5 SnAgSnAgSnAgSnAff=f7f)Nc>[TS5$)Nr)WriteSubprocessPipeProtorOsr68BaseSubprocessTransport._connect_pipes..s 4T1=rErc>[TS5$)NrReadSubprocessPipeProtorOsr6rr 3D![TS5$)Nr rrOsr6rrrrEr )rrrconnect_write_piper rconnect_read_piper call_soonrconnection_mader cancelled set_result SystemExitKeyboardInterrupt BaseException set_exception) r.r1procr/_r?callbackdataexcs ` r6r-&BaseSubprocessTransport._connect_pipess# (::D::Dzz% $ 7 7=JJ!  "& A{{& $ 6 6<KK!!!"& A{{& $ 6 6<KK!!!"& A NN4>>994 @"&"5"5x/$/#6"&D !&*:*:*<*<!!$'+=!; ! !-.   *!&*:*:*<*<$$S))+=! *shGAE7 E0AE7E3AE7E5A*E7,G0E73E75E77G)G :G GGcURbURRX45 gURR"U/UQ76 grG)rr=rr)r.cbrs r6_callBaseSubprocessTransport._calls;    *    & &z 2 JJ  +d +rEcpURURRX5 UR5 grG)rrpipe_connection_lost _try_finish)r.rlrs r6_pipe_connection_lost-BaseSubprocessTransport._pipe_connection_losts& 4>>66@ rEcPURURRX5 grG)rrpipe_data_received)r.rlrs r6_pipe_data_received+BaseSubprocessTransport._pipe_data_receiveds 4>>44b?rEc4URR5(a[R"SX5 XlUR R cXR lURURR5 UR5 g)Nz%r exited with return code %r) rr'rrBrr returncoderrprocess_exitedr)r.rs r6_process_exited'BaseSubprocessTransport._process_exitedsj ::   ! ! KK7 J% :: (%/JJ ! 4>>001 rEc# URb UR$URR5nURR U5 UIShvN $N7f)z\Wait until the process exit and return the process return code. This method is a coroutine.N)rr create_futurerr=)r.r1s r6_waitBaseSubprocessTransport._waitsO    '## #))+ !!&)||sAAAAcURcg[SURR555(a$SUlUR UR S5 gg)Nc3P# UHnUSL=(a URv M g7frG) disconnected).0ps r6 6BaseSubprocessTransport._try_finish..s'.,1}//,s$&T)rallr rVr!r_call_connection_lostrOs r6r#BaseSubprocessTransport._try_finishsX    #  . **,. . .!DN JJt114 8 .rEcURRU5 URH5nUR5(aMUR UR 5 M7 SUlSUlSUlSUlg!URH5nUR5(aMUR UR 5 M7 SUlSUlSUlSUlf=frG)rconnection_lostrrrrrr)r.rr1s r6r-BaseSubprocessTransport._call_connection_losts " NN * *3 /,,''))%%d&6&67-"&D DJDJ!DN ,,''))%%d&6&67-"&D DJDJ!DNsA??#C"&)r5r<rlr?rOs r6rC!WriteSubprocessPipeProto.__repr__!s04>>**+4ytyym1MMrEclSUlURRURU5 SUlg)NT)rrrrl)r.rs r6r(WriteSubprocessPipeProto.connection_lost$s)  ''5 rEcLURRR5 grG)rr pause_writingrOs r6r&WriteSubprocessPipeProto.pause_writing)s ))+rEcLURRR5 grG)rrresume_writingrOs r6r'WriteSubprocessPipeProto.resume_writing,s **,rE)rrlr?rN) r<rrrrrrCrrrrrrEr6rrs!" N ,-rErc\rSrSrSrSrg)ri0cPURRURU5 grG)rrrl)r.rs r6 data_received%ReadSubprocessPipeProto.data_received3s %%dggt4rErN)r<rrrrrrrEr6rr0s5rEr)rrrr~rvrrrlogrSubprocessTransportr BaseProtocolrProtocolrrrEr6rs] F"j<<F"R-y55-456'005rE