/g" d dl Z d dlZd dlZddlmZ ddlmZ ddlmZ G d dej Z G d d ej
Z G d
d e ej Z
dS ) N ) protocols)
transports)loggerc e Zd Z d fd Zd Zd Zd Zd Zd Zd Z e
j fd Z d
Z
d Zd Zd
Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Z xZ S )BaseSubprocessTransportNc
D t |
d| _ || _ || _ d | _ d | _ d | _ g | _ t j
| _ i | _ d| _
|t j k r
d | j d< |t j k r
d | j d< |t j k r
d | j d< | j d||||||d| n# | xY w| j j | _ | j | j d< | j rBt+ |t, t. f r|} n|d } t1 j d| | j | j | | d S ) 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 >/opt/alt/python311/lib64/python3.11/asyncio/base_subprocess.pyr z BaseSubprocessTransport.__init__ s !
) / 1 1 JO # # !DKN Z_ $ $ !DKN Z_ $ $ !DKN DK
BTeF %w
B
B:@
B
B
B
B JJLLL JN $(J L! : ! ! -$ --
" q' L5 $)
-
-
-
t 2 26 : :;;;;;s C C5c 8 | j j g}| j r| d | j | d| j | j | d| j n2| j | d n| d | j d }| | d|j | j d }| j d }|"||u r | d
|j n>| | d |j | | d |j d
d
| 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 s '( < " KK ! ! ! 9 KK*ty** + + + ' KK8d&688 9 9 9 9
Y
" KK " " " " KK
& & & "" KK--- . . . ## ## &F"2"2 KK666 7 7 7 7! 3fk 3 3444! 3fk 3 3444}}SXXd^^,,, c t N)NotImplementedError)r- r r r
r r r r2 s r5 r" z BaseSubprocessTransport._startT s !!rB c || _ d S 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 rd S d| _ | j D ] }||j | j {| j v| j _| j rt j d| | j d S # t $ r Y d S w xY wd S d S d S )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 < F ['')) E} J J " (
!!)z##%%
M EtLLL
!!!!!%
# "(( *)s B: :
CCc l | j s, |d| t | | d S d S )Nzunclosed transport )source)r ResourceWarningr# )r- _warns r5 __del__z BaseSubprocessTransport.__del__{ sG | E000/$ O O O O JJLLLLL rB c | j S rD )r rJ s r5 get_pidz BaseSubprocessTransport.get_pid s
yrB c | j S rD )r rJ s r5 get_returncodez&BaseSubprocessTransport.get_returncode s rB c < || j v r| j | j S d S rD )r r= )r- fds r5 get_pipe_transportz*BaseSubprocessTransport.get_pipe_transport s#
;r?' '4rB c 0 | j t d S rD )r rS rJ s r5 _check_procz#BaseSubprocessTransport._check_proc s : $&& & rB c b | | j | d S rD )rb r send_signal)r- signals r5 rd z#BaseSubprocessTransport.send_signal s0
v&&&&&rB c ` | | j d S rD )rb r terminaterJ s r5 rg z!BaseSubprocessTransport.terminate s.
rB c ` | | j d S rD )rb r rR rJ s r5 rR z BaseSubprocessTransport.kill s,
rB c K j } j }|j 1| fd|j d {V \ }}| j d< |j 1| fd|j d {V \ }}| j d< |j 1| fd|j d {V \ }}| j d< | j j
j D ]\ }} |j |g|R d _ |+| s|
d d S d S d S # t t f$ r t $ rB}|/| s!| | Y d }~d S Y d }~d S Y d }~d S d }~ww xY w)Nc $ t d S )Nr )WriteSubprocessPipeProtorJ s r5