e$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/imh/python3.13/lib/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 ||rEcUR(agSUlURR5H"nUcMURR 5 M$ UR b|UR cnUR R5cRURR5(a[R"SU5 UR R5 gggg![[4a gf=f)NTz$Close running child process: kill %r)rr valuesr?r$rrpollrr'rwarningkillProcessLookupErrorPermissionError)r.protos r6r$BaseSubprocessTransport.closecs <<  [['')E} JJ   * JJ "  ( !)zz##%%EtL  ! *) #'8  sC$$C76C7chUR(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)rrZrOs r6 _check_proc#BaseSubprocessTransport._check_procs :: $& & rEwin32cZUR5 URRU5 grG)ror send_signalr.signals r6rs#BaseSubprocessTransport.send_signals     JJ " "6 *rEcXUR5 URR5 grG)ror terminaterOs r6rx!BaseSubprocessTransport.terminates     JJ "rEcXUR5 URR5 grG)rorrYrOs r6rYBaseSubprocessTransport.kills     JJOO rEcUR5 [R"URRU5 g![ a gf=frG)roosrYrr%rZrts r6rsrvs;      /%  s+> A  A cBUR[R5 grG)rsruSIGTERMrOs r6rxry   V^^ ,rEcBUR[R5 grG)rsruSIGKILLrOs r6rYr{rrEc^# TRnTRnURb9URU4SjUR5IShvN upEUTRS'UR b9UR U4SjUR 5IShvN upEUTRS'URb9UR U4SjUR5IShvN upEUTRS'TRceURTRRT5 TRHupgUR"U/UQ76 M STlUb(UR5(dURS5 gggGN2NN![[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_piperr call_soonrconnection_made 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&&2 22 NN4>>994 @"&"5"5x/$/#6"&D !&*:*:*<*<!!$'+=!; ! !-.   *!&*:*:*<*<$$S))+=! *shG AF E?AFFAFFA9F,G ?FFFG )G G GG cURbURRX45 gURR"U/UQ76 grG)rr=rr)r.cbrs r6_callBaseSubprocessTransport._calls;    *    & &z 2 JJ  +d +rEcpURURRX5 UR5 grG)rrpipe_connection_lost _try_finish)r.rkrs r6_pipe_connection_lost-BaseSubprocessTransport._pipe_connection_losts& 4>>66@ rEcPURURRX5 grG)rrpipe_data_received)r.rkrs r6_pipe_data_received+BaseSubprocessTransport._pipe_data_receiveds 4>>44b?rEcUcU5eURbUR5eURR5(a[R"SX5 XlUR R cXR lURURR5 UR5 g)Nz%r exited with return code %r) rrr'rrBr returncoderrprocess_exitedr)r.rs r6_process_exited'BaseSubprocessTransport._process_exiteds%1z1%'9)9)99' ::   ! ! 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    '## #))+ !!&)||sAAAAcUR(aeURcg[SURR 555(a$SUlUR UR S5 gg)Nc3P# UHnUSL=(a URv M g7frG) disconnected).0ps r6 6BaseSubprocessTransport._try_finish..s'.,1}//,s$&T)r!rallr rVr_call_connection_lostrOs r6r#BaseSubprocessTransport._try_finishse>>!!    #  . **,. . .!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<rkr?rOs r6rC!WriteSubprocessPipeProto.__repr__s04>>**+4ytyym1MMrEclSUlURRURU5 SUlg)NT)rrrrk)r.rs r6r(WriteSubprocessPipeProto.connection_losts)  ''5 rEcLURRR5 grG)rr pause_writingrOs r6r&WriteSubprocessPipeProto.pause_writing$s ))+rEcLURRR5 grG)rrresume_writingrOs r6r'WriteSubprocessPipeProto.resume_writing's **,rE)rrkr?rN) r<rrrrrrCrrrrrrEr6rrs!" N ,-rErc\rSrSrSrSrg)ri+cPURRURU5 grG)rrrk)r.rs r6 data_received%ReadSubprocessPipeProto.data_received.s %%dggt4rErN)r<rrrrrrrEr6rr+s5rEr)rrrr}rurrrlogrSubprocessTransportr BaseProtocolrProtocolrrrEr6rs] A"j<<A"H-y55-456'005rE