E,bic(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 SUlU[R :XaSURS'U[R :XaSURS'U[R :XaSURS'UR""SX4XVXxS.U D6 UR R&UlUR UR(S'URR+5(aD[-U[.[045(aUn OUSn [2R4"SXR 5 URR7UR9U 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 _finished_pipes_connectedrPIPE_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__sx  !   )//1  % JOO #!DKKN Z__ $!DKKN Z__ $!DKKN  KK BTe% B:@ B JJNN $(JJ L! ::   ! !$ --q' LL5 )) - t226:;  JJL s F11GcvURR/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<{}> ) r6__name__rappendrrr getpipeformatjoin)r/inforrrs r7__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 rrrrr4s r7r$BaseSubprocessTransport._startXs!!rFcXlgrHr)r/r1s r7 set_protocol$BaseSubprocessTransport.set_protocol[s!rFcUR$rHrLr/s r7 get_protocol$BaseSubprocessTransport.get_protocol^s ~~rFcUR$rH)rrPs r7 is_closing"BaseSubprocessTransport.is_closingas ||rFc\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 r7r%BaseSubprocessTransport.closeds <<  [['')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 r7__del__BaseSubprocessTransport.__del__s+|| 'x0/$ O JJLrFcUR$rH)rrPs r7get_pidBaseSubprocessTransport.get_pids yyrFcUR$rH)rrPs r7get_returncode&BaseSubprocessTransport.get_returncodesrFcTXR;aURUR$grH)r r@)r/fds r7get_pipe_transport*BaseSubprocessTransport.get_pipe_transports#  ;;r?'' 'rFc2URc [5egrH)rr\rPs r7 _check_proc#BaseSubprocessTransport._check_procs :: $& & rFwin32cZUR5 URRU5 grH)rqr send_signalr/signals r7ru#BaseSubprocessTransport.send_signals     JJ " "6 *rFcXUR5 URR5 grH)rqr terminaterPs r7rz!BaseSubprocessTransport.terminates     JJ "rFcXUR5 URR5 grH)rqrr[rPs r7r[BaseSubprocessTransport.kills     JJOO rFcUR5 [R"URRU5 g![ a gf=frH)rqosr[rr&r\rvs r7rurxs;      /%  s+> A  A cBUR[R5 grH)rurwSIGTERMrPs r7rzr{   V^^ ,rFcBUR[R5 grH)rurwSIGKILLrPs r7r[r}rrFc^# TRnTRnURb9URU4SjUR5IShvN upEUTRS'UR b9UR U4SjUR 5IShvN upEUTRS'URb9UR U4SjUR5IShvN upEUTRS'URTRRT5 TRHupgUR"U/UQ76 M STl Ub&UR5(dURS5 STlgGN(NN![[ 4a e["a=nUb0UR5(dUR%U5 SnAgSnAgSnAgSnAff=f7f)Nc>[TS5$)Nr)WriteSubprocessPipeProtorPsr78BaseSubprocessTransport._connect_pipes..s 4T1=rFrc>[TS5$)NrReadSubprocessPipeProtorPsr7rr 3D![TS5$)Nr rrPsr7rrrrFr T)rrrconnect_write_piper rconnect_read_piper call_soonrconnection_mader cancelled set_resultr" SystemExitKeyboardInterrupt BaseException set_exception) r/r2procr0_r@callbackdataexcs ` r7r.&BaseSubprocessTransport._connect_pipess$ )::D::Dzz% $ 7 7=JJ!  "& A{{& $ 6 6<KK!!!"& A{{& $ 6 6<KK!!!"& A NN4>>994 @"&"5"5x/$/#6"&D !&*:*:*<*<!!$'$(D !? ! !-.   *!&*:*:*<*<$$S))+=! *shGAE< E5AE<E8AE<E:A*E<1G5E<8E<:E<<G)G?GGGcURbURRX45 gURR"U/UQ76 grH)rr>rr)r/cbrs r7_callBaseSubprocessTransport._calls;    *    & &z 2 JJ  +d +rFcpURURRX5 UR5 grH)rrpipe_connection_lost _try_finish)r/rmrs r7_pipe_connection_lost-BaseSubprocessTransport._pipe_connection_losts& 4>>66@ rFcPURURRX5 grH)rrpipe_data_received)r/rmrs r7_pipe_data_received+BaseSubprocessTransport._pipe_data_receiveds 4>>44b?rFc4URR5(a[R"SX5 XlUR R cXR lURURR5 UR5 g)Nz%r exited with return code %r) rr(rrCrr returncoderrprocess_exitedr)r/rs r7_process_exited'BaseSubprocessTransport._process_exitedsj ::   ! ! KK7 J% :: (%/JJ ! 4>>001 rFc# 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/r2s r7_waitBaseSubprocessTransport._waitsO    '## #))+ !!&)||sAAAAcrURcgUR(dEURH5nUR5(aMUR UR5 M7 [ SUR R555(a$SUlURURS5 gg)Nc3P# UHnUSL=(a URv M g7frH) disconnected).0ps r7 6BaseSubprocessTransport._try_finish..s'.,1}//,s$&T) rr"rrrallr rWr!r_call_connection_lostrs r7r#BaseSubprocessTransport._try_finishs    # $$ ,,''))%%d&6&67- . **,. . .!DN JJt114 8 .rFcURRU5 URH5nUR5(aMUR UR 5 M7 SUlSUlSUlSUlg!URH5nUR5(aMUR UR 5 M7 SUlSUlSUlSUlf=frH)rconnection_lostrrrrrr)r/rr2s r7r-BaseSubprocessTransport._call_connection_losts " NN * *3 /,,''))%%d&6&67-"&D DJDJ!DN ,,''))%%d&6&67-"&D DJDJ!DNsA??#C"&)r6r=rmr@rPs r7rD!WriteSubprocessPipeProto.__repr__,s04>>**+4ytyym1MMrFclSUlURRURU5 SUlg)NT)rrrrm)r/rs r7r(WriteSubprocessPipeProto.connection_lost/s)  ''5 rFcLURRR5 grH)rr pause_writingrPs r7r&WriteSubprocessPipeProto.pause_writing4s ))+rFcLURRR5 grH)rrresume_writingrPs r7r'WriteSubprocessPipeProto.resume_writing7s **,rF)rrmr@rN) r=rrrrrrDrrrrrrFr7rr!s!" N ,-rFrc\rSrSrSrSrg)ri;cPURRURU5 grH)rrrm)r/rs r7 data_received%ReadSubprocessPipeProto.data_received>s %%dggt4rFrN)r=rrrrrrrFr7rr;s5rFr)rrrrrwrrrlogrSubprocessTransportr BaseProtocolrProtocolrrrFr7rs] Q"j<<Q"h-y55-456'005rF