*jY( S SK r S SKrS SKrS SKrS SKrS SKrSSKJr SSKJr SSK J
r
" S S\R 5 r " S S \R 5 r " S
S \\R 5 rg) N ) protocols)
transports)loggerc ^ \ rS rSr S U 4S jjrS rS rS rS rS r S r
\ R 4S jr
S
rS rS rS
r\R& S:X a
S rS rS rO S rS rS rS rS rS rS rS rS r S r S r S r U =r $ ) BaseSubprocessTransport
c
> [ T
U ] U
5 SU l X l Xl S U l S U l S U l / U l [ R " 5 U l 0 U l SU l
SU l U[ R :X a S U R S' U[ R :X a S U R S' U[ R :X a S U R S' U R" " SX4XVXxS.U D6 U R
R& U l U R
U R( S' U R R+ 5 ( aD [- U[. [0 45 ( a Un OUS n [2 R4 " SXR 5 U R R7 U R9 U 5 5 g ! U R% 5 e = f) NFr r )argsshellstdinstdoutstderrbufsize
subprocesszprocess %r created: pid %s ) super__init___closed _protocol_loop_proc_pid _returncode
_exit_waiters collectionsdeque_pending_calls_pipes _finished_pipes_connectedr PIPE_startclosepid_extra get_debug
isinstancebytesstrr debug create_task_connect_pipes)selfloopprotocolr r
r r r r waiterextrakwargsprogram __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 ))
-
t 2 26 :; JJL s F1 1Gc v U R R /nU R ( a UR S5 U R b UR SU R 35 U R
b UR SU R
35 O0U R b UR S5 OUR S5 U R R S5 nUb UR SUR 35 U R R S5 nU R R S 5 nUb# XCL a UR S
UR 35 OBUb UR S UR 35 Ub UR S UR 35 S
R SR U5 5 $ )Nclosedzpid=z returncode=runningz not startedr zstdin=r r zstdout=stderr=zstdout=zstderr=z<{}> ) r6 __name__r appendr r r getpipeformatjoin)r/ infor r r s 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
r r r r r4 s r7 r$ BaseSubprocessTransport._startX s !!rF c Xl g rH r )r/ r1 s r7 set_protocol$BaseSubprocessTransport.set_protocol[ s !rF c U R $ rH rL r/ s r7 get_protocol$BaseSubprocessTransport.get_protocol^ s ~~ rF c U R $ rH )r rP s r7
is_closing"BaseSubprocessTransport.is_closinga s ||rF c \ U R ( a g SU l U R R 5 HV nUc M U R ( d M U R R 5 ( a M< UR
R
5 MX U R b| U R cn U R R 5 cR U R R 5 ( a [ R " SU 5 U R R 5 g g g g ! [ [ 4 a g f = f)NTz$Close running child process: kill %r)r r valuesr is_closedr@ r% r r pollr( r warningkillProcessLookupErrorPermissionError)r/ protos r7 r% BaseSubprocessTransport.closed s << [['')E}
zzz$**"6"6"8"8
" *
JJ " (
!)zz##%% EtL
!
* )
# '8
s :D D+*D+c h U R ( d! U" SU < 3[ U S9 U R 5 g g )Nzunclosed transport )source)r ResourceWarningr% )r/ _warns r7 __del__ BaseSubprocessTransport.__del__ s+ || 'x0/$ O JJL rF c U R $ rH )r rP s r7 get_pid BaseSubprocessTransport.get_pid s yyrF c U R $ rH )r rP s r7 get_returncode&BaseSubprocessTransport.get_returncode s rF c T XR ; a U R U R $ g rH )r r@ )r/ fds r7 get_pipe_transport*BaseSubprocessTransport.get_pipe_transport s#
;;r?'' 'rF c 2 U R c
[ 5 eg rH )r r\ rP s r7 _check_proc#BaseSubprocessTransport._check_proc s :: $& & rF win32c Z U R 5 U R R U5 g rH )rq r send_signalr/ signals r7 ru #BaseSubprocessTransport.send_signal s JJ " "6 *rF c X U R 5 U R R 5 g rH )rq r terminaterP s r7 rz !BaseSubprocessTransport.terminate s JJ "rF c X U R 5 U R R 5 g rH )rq r r[ rP s r7 r[ BaseSubprocessTransport.kill s JJOO rF c U R 5 [ R " U R R U5 g ! [
a g f = frH )rq osr[ r r& r\ rv s r7 ru rx s;
/%
s +>
A
A c B U R [ R 5 g rH )ru rw SIGTERMrP s r7 rz r{ V^^ ,rF c B U R [ R 5 g rH )ru rw SIGKILLrP s r7 r[ r} r rF c ^ # T R nT R nUR b9 UR U 4S jUR 5 I S h vN u pEUT R S' UR
b9 UR
U 4S jUR
5 I S h vN u pEUT R S' UR b9 UR
U 4S jUR 5 I S h vN u pEUT R S' UR T R R T 5 T R H u pgUR " U/UQ76 M S T l Ub& UR 5 ( d UR S 5 ST l g GN( N N! [ [ 4 a e [" a= nUb0 UR 5 ( d UR% U5 S nAg S nAg S nAg S nAff = f7f)Nc > [ T S5 $ )Nr )WriteSubprocessPipeProtorP s r7 8BaseSubprocessTransport._connect_pipes.. s
4T1 =rF r c > [ T S5 $ )Nr ReadSubprocessPipeProtorP s r7 r r
3D! [ T S5 $ )Nr r rP s r7 r r r rF r T)r r r connect_write_piper r connect_read_piper call_soonr connection_mader cancelled
set_resultr"
SystemExitKeyboardInterrupt
BaseException
set_exception) r/ r2 procr0 _r@ callbackdataexcs ` r7 r. &BaseSubprocessTransport._connect_pipes s $ )::D::Dzz% $ 7 7=JJ! "& A{{& $ 6 6<KK!! ! "& A{{& $ 6 6<KK!! ! "& A
NN4>>994 @"&"5"5x/$/ #6"&D !&*:*:*<*<!!$'$(D !? ! ! -. *!&*:*:*<*<$$S)) +=! *sh GAE<
E5AE< E8AE< E:A*E< 1G5E< 8E< :E< <G)G?GGGc U R b U R R X45 g U R R " U/UQ76 g rH )r r> r r )r/ cbr s r7 _call BaseSubprocessTransport._call s; * & &z 2 JJ +d +rF c p U R U R R X5 U R 5 g rH )r r pipe_connection_lost _try_finish)r/ rm r s r7 _pipe_connection_lost-BaseSubprocessTransport._pipe_connection_lost s&
4>>66@ rF c P U R U R R X5 g rH )r r pipe_data_received)r/ rm r s r7 _pipe_data_received+BaseSubprocessTransport._pipe_data_received s
4>>44b?rF c 4 U R R 5 ( a [ R " SX5 Xl U R
R c XR
l U R U R R 5 U R 5 g )Nz %r exited with return code %r) r r( r rC r r
returncoder r process_exitedr )r/ r s r7 _process_exited'BaseSubprocessTransport._process_exited sj :: ! ! KK7 J% :: ( %/JJ !
4>>001 rF c # U R b U R $ U R R 5 nU R R U5 UI Sh vN $ N7f)z\Wait until the process exit and return the process return code.
This method is a coroutine.N)r r
create_futurer r> r/ r2 s r7 _wait BaseSubprocessTransport._wait sO '## #))+ !!&)||s AA AA c r U R c g U R ( dE U R H5 nUR 5 ( a M UR U R 5 M7 [ S U R R 5 5 5 ( a$ SU l U R U R S 5 g g )Nc 3 P # U H nUS L=( a UR v M g 7frH ) disconnected).0ps r7 6BaseSubprocessTransport._try_finish.. s' .,1 }/ /,s $&T) r r" r doner allr rW r! r _call_connection_lostr s r7 r #BaseSubprocessTransport._try_finish s # $$ ,, {{}}%%d&6&67 - . **,. . . !DN JJt114 8 .rF c U R R U5 U R H5 nUR 5 ( a M UR U R
5 M7 S U l S U l S U l S U l g ! U R H5 nUR 5 ( a M UR U R
5 M7 S U l S U l S U l S U l f = frH )r connection_lostr r r r r r )r/ r r2 s r7 r -BaseSubprocessTransport._call_connection_lost s
" NN * *3 / ,, {{}}%%d&6&67 - "&D DJ DJ !DN
,, {{}}%%d&6&67 - "&D DJ DJ !DNs A? ?#C"&)r6 r= rm r@ rP s r7 rD !WriteSubprocessPipeProto.__repr__, s0 4>>**+4ytyym1MMrF c l SU l U R R U R U5 S U l g )NT)r r r rm )r/ r s r7 r (WriteSubprocessPipeProto.connection_lost/ s) ''5 rF c L U R R R 5 g rH )r r
pause_writingrP s r7 r &WriteSubprocessPipeProto.pause_writing4 s ))+rF c L U R R R 5 g rH )r r resume_writingrP s r7 r 'WriteSubprocessPipeProto.resume_writing7 s **,rF )r rm r@ r N) r= r r r r r rD r r r r r rF r7 r r ! s! " N
,-rF r c \ rS rSrS rSrg)r i; c P U R R U R U5 g rH )r r rm )r/ r s r7
data_received%ReadSubprocessPipeProto.data_received> s %%dggt4rF r N)r= r r r r r r rF r7 r r ; s 5rF r )r r r r rw r r r logr SubprocessTransportr BaseProtocolr Protocolr r rF r7 r s]
Q"j < < Q"h-y 5 5 -45 6 ' 0 05rF