֦i" d dl Z d dlZd dlZddlmZ ddlmZ ddlmZ G d dej Z G d d ej Z G d
d e ej Z
y) N ) protocols)
transports)loggerc e Zd Z d fd Zd Zd Zd Zd Zd Zd Z e
j fdZ d Z
d
Zd Zd Zd
Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Z xZ S )BaseSubprocessTransportc
n t
| |
d| _ || _ || _ d | _ d | _ d | _ g | _ t j | _ i | _ d| _
|t j k( rd | j d< |t j k( rd | j d< |t j k( rd | j d< | j d||||||d| | j
j$ | _ | j
| j& d< | j j) r?t+ |t, t. f r|} n|d } t1 j2 d| | j | j j5 | j7 | y # | j# xY w) NFr r )argsshellstdinstdoutstderrbufsize
subprocesszprocess %r created: pid %s ) super__init___closed _protocol_loop_proc_pid _returncode
_exit_waiters collectionsdeque_pending_calls_pipes _finishedr PIPE_startclosepid_extra get_debug
isinstancebytesstrr debug create_task_connect_pipes)selfloopprotocolr r r
r r r waiterextrakwargsprogram __class__s 0/usr/lib64/python3.12/asyncio/base_subprocess.pyr z BaseSubprocessTransport.__init__ sx !
) / / 1 JOO # !DKKN Z__ $ !DKKN Z__ $ !DKKN DKK
BTeF %w
B:@
B JJNN $(JJ L! :: !$ - q' LL5 $))
-
t 2 26 :; JJL s F! !F4c ^ | j j g}| j r|j d | j |j d| j | j
|j d| j
n/| j |j d n|j d | j j d }| |j d|j | j j d }| j j d }|#||u r |j d
|j n@| |j d |j | |j d |j d
j dj | S )Nclosedzpid=z returncode=runningz not startedr zstdin=r r
zstdout=stderr=zstdout=zstderr=z<{}> ) r4 __name__r appendr r r getpipeformatjoin)r- infor
r r s r5 __repr__z BaseSubprocessTransport.__repr__7 sX ''( << KK ! 99 KK$tyyk* + ' KK+d&6&6%78 9
YY
" KK " KK
& " KK& - . # # &F"2 KK.
6 7! gfkk] 34! gfkk] 34}}SXXd^,, c t N)NotImplementedError)r- r r r
r r r r2 s r5 r" z BaseSubprocessTransport._startT s !!rB c || _ y rD r )r- r/ s r5 set_protocolz$BaseSubprocessTransport.set_protocolW s !rB c | j S rD rG r- s r5 get_protocolz$BaseSubprocessTransport.get_protocolZ s ~~ rB c | j S rD )r rJ s r5
is_closingz"BaseSubprocessTransport.is_closing] s ||rB c | j ry d| _ | j j D ] }||j j ! | j
t| j g| j
j L| j j rt j d| | j
j y y y y # t $ r Y y w xY w)NTz$Close running child process: kill %r)r r valuesr= r# r r pollr r& r warningkillProcessLookupError)r- protos r5 r# z BaseSubprocessTransport.close` s << [['')E} JJ *
JJ " (
!)zz##% EtL
!
* )
# &
s 4C C C c b | j s# |d| t | | j y y )Nzunclosed transport )source)r ResourceWarningr# )r- _warns r5 __del__z BaseSubprocessTransport.__del__{ s+ || 'x0/$ O JJL rB c | j S rD )r rJ s r5 get_pidz BaseSubprocessTransport.get_pid s yyrB c | j S rD )r rJ s r5 get_returncodez&BaseSubprocessTransport.get_returncode s rB c R || j v r| j | j S y rD )r r= )r- fds r5 get_pipe_transportz*BaseSubprocessTransport.get_pipe_transport s%
;;r?'' 'rB c 0 | j
t y rD )r rS rJ s r5 _check_procz#BaseSubprocessTransport._check_proc s :: $& & rB c Z | j | j j | y rD )rb r send_signal)r- signals r5 rd z#BaseSubprocessTransport.send_signal s
v&rB c X | j | j j y rD )rb r terminaterJ s r5 rg z!BaseSubprocessTransport.terminate s
rB c X | j | j j y rD )rb r rR rJ s r5 rR z BaseSubprocessTransport.kill s
rB c K j } j }|j 9|j fd|j d { \ }}| j d< |j
9|j
fd|j
d { \ }}| j d< |j 9|j
fd|j d { \ }}| j d< |j j j j D ] \ }} |j |g| d _ |#|j s|j d y y y 7 7 7 # t t f$ r t $ r7}|+|j s|j# | Y d }~y Y d }~y Y d }~y d }~ww xY ww)Nc t d S )Nr )WriteSubprocessPipeProtorJ s r5 z8BaseSubprocessTransport._connect_pipes.. s
4T1 =rB r c t d S )Nr ReadSubprocessPipeProtorJ s r5 rl z8BaseSubprocessTransport._connect_pipes..
3D! . rp rB r
)r r r
connect_write_piper r connect_read_piper call_soonr connection_mader cancelled
set_result
SystemExitKeyboardInterrupt
BaseException
set_exception) r- r0 procr. _r= callbackdataexcs ` r5 r, z&BaseSubprocessTransport._connect_pipes s # (::D::Dzz% $ 7 7=JJ! 4 "& A{{& $ 6 6<KK!! !4 "& A{{& $ 6 6<KK!! !4 "& A
NN4>>994 @"&"5"5$ x/$/ #6"&D !&*:*:*<!!$' +=!; ! ! -. *!&*:*:*<$$S)) +=! *sh F?AE- E& AE- E)AE- E+A*E- &F?&E- )E- +E- -F<#F7(F?7F<<F?c | j | j j ||f y | j j |g| y rD )r r; r rt )r- cbr s r5 _callz BaseSubprocessTransport._call s? * & &Dz 2 DJJ +d +rB c r | j | j j || | j y rD )r r pipe_connection_lost _try_finish)r- r_ r s r5 _pipe_connection_lostz-BaseSubprocessTransport._pipe_connection_lost s(
4>>66C@ rB c R | j | j j || y rD )r r pipe_data_received)r- r_ r s r5 _pipe_data_receivedz+BaseSubprocessTransport._pipe_data_received s
4>>44b$?rB c , | j j rt j d| | || _ | j
j || j
_ | j | j j | j y )Nz %r exited with return code %r) r r& r r@ r r
returncoder r process_exitedr )r- r s r5 _process_exitedz'BaseSubprocessTransport._process_exited sm :: ! KK7z J% :: ( %/DJJ !
4>>001 rB c K | j | j S | j j }| j j | | d { S 7 wrD )r r
create_futurer r; )r- r0 s r5 _waitz BaseSubprocessTransport._wait sU ' '## #))+ !!&)||s AA AA c | j y t d | j j D r$d| _ | j | j d y y )Nc 3 @ K | ] }|d uxr |j y wrD ) disconnected).0ps r5 z6BaseSubprocessTransport._try_finish.. s( .,1 }/ /,s T)r allr rO r r _call_connection_lostrJ s r5 r z#BaseSubprocessTransport._try_finish sS # . **,. . !DN JJt114 8 .rB c | j j | | j D ]. }|j r|j | j
0 d | _ d | _ d | _ d | _ y # | j D ]. }|j r|j | j
0 d | _ d | _ d | _ d | _ w xY wrD )r connection_lostr rv rw r r r )r- r r0 s r5 r z-BaseSubprocessTransport._call_connection_lost s
" NN * *3 / ,, '')%%d&6&67 - "&D DJ DJ !DN
,, '')%%d&6&67 - "&D DJ DJ !DNs A7 7 C:C)NN) r:
__module__ __qualname__r rA r" rH rK rM r# warningswarnrY r[ r] r` rb rd rg rR r, r r r r r r r
__classcell__)r4 s @r5 r r
s %)))r4 r: r_ r= rJ s r5 rA z!WriteSubprocessPipeProto.__repr__
s0 4>>**+4ytyym1MMrB c l d| _ | j j | j | d | _ y )NT)r r| r r_ )r- r s r5 r z(WriteSubprocessPipeProto.connection_lost
s) ''5 rB c L | j j j y rD )r| r
pause_writingrJ s r5 r z&WriteSubprocessPipeProto.pause_writing s ))+rB c L | j j j y rD )r| r resume_writingrJ s r5 r z'WriteSubprocessPipeProto.resume_writing s **,rB N) r: r r r ru rA r r r r rB r5 rk rk s! " N
,-rB rk c e Zd Zd Zy)ro c P | j j | j | y rD )r| r r_ )r- r s r5
data_receivedz%ReadSubprocessPipeProto.data_received s %%dggt4rB N)r: r r r r rB r5 ro ro s 5rB ro )r r r r r logr SubprocessTransportr BaseProtocolrk Protocolro r rB r5 r sT r"j < < r"j-y 5 5 -45 6 ' 0 05rB