{|j" 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 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