Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]

a

XC?h�"�@sxdd
lZdd
l
Z
dd
lZddlmZ
ddlmZ
ddlmZ
Gdd�dej�Z	Gdd	�d	ej
�ZGd
d�deej�Z
d
S)�N�
)
�	protocols)
�
transports)
�loggercs�eZ
dZd0�f
dd�	Zdd�Zdd�Zdd	�Zd
d�Zdd
�Zdd�Z	e
jf
dd�
Zdd�Z
dd�Zdd�Zdd�Zdd�Zdd�Zdd�Zd d!�Zd"d#�Zd$d%�Zd&d'�Zd(d)�Zd*d+�Zd,d-�Zd.d/�Z�ZS)1�BaseSubprocessTransportNc
	s&
t��
|
�

d
|_||_|
|_d|_d|_d|_g|_t	�
�|_i|_d
|_
|tjkr`d|jd<|tjkrtd|jd<|tjkr�d|jd<z"|jf||||||d�|�
�

Wn


|��
�Yn0|jj|_|j|jd<|j���
rt|ttf�r�|}n|d}t�d||j�
|j�|�|	�
�

dS)NFr
r�)�args�shell�stdin�stdout�stderr�bufsize�
subprocesszprocess %r created: pid %s)�super�__init__�_closed�	_protocol�_loop�_proc�_pid�_returncode�
_exit_waiters�collections�deque�_pending_calls�_pipes�	_finishedr�PIPE�_start�close�pidZ_extra�	get_debug�
isinstance�bytes�strr�debugZcreate_task�_connect_pipes)
�self�loop�protocolrr	r
rrr
�waiterZextra�kwargsZprogram�
�	__class__��</opt/alt/python39/lib64/python3.9/asyncio/base_subprocess.pyrsH























�
�








�z BaseSubprocessTransport.__init__c
Cs
|jj
g
}
|jr|
�d
�

|jdu
r6|
�d|j���

|jdu
rT|
�d|j���

n |jdu
rj|
�d�

n
|
�d�

|j�d�
}|du
r�|
�d|j���

|j�d�
}|j�d	�
}|du
r�||ur�|
�d
|j���

n6|du
r�|
�d|j���

|du
�
r|
�d|j���

d
�	d�
|
�
�
S)N�closedzpid=zreturncode=Zrunningznot startedr
zstdin=rrzstdout=stderr=zstdout=zstderr=z<{}>�
 )r-�__name__r�appendrrr�get�pipe�format�join)r'�infor
rrr.r.r/�__repr__7s,























z BaseSubprocessTransport.__repr__c
Kst�
dS�
N)
�NotImplementedError)r'rr	r
rrr
r+r.r.r/rTs
zBaseSubprocessTransport._startcCs
|
|_dSr:�
r)r'r)r.r.r/�set_protocolWs
z$BaseSubprocessTransport.set_protocolc


Cs|jSr:r<�
r'r.r.r/�get_protocolZs
z$BaseSubprocessTransport.get_protocolc


Cs|jSr:)
rr>r.r.r/�
is_closing]s
z"BaseSubprocessTransport.is_closingc
Cs�|jr
dSd
|_|j
��D]}
|
dur(q|
j��
q|jdu
r�|jdur�|j��dur�|j�	�rlt
�d|�
z|j��
Wnt
y�


Yn0dS)NTz$Close running child process: kill %r)rr�valuesr5rrrZpollrr!rZwarning�kill�ProcessLookupError)r'�protor.r.r/r`s$






��




zBaseSubprocessTransport.closecCs&|js"|
d
|��t
|d�
|��
dS)Nzunclosed transport )
�source)r�ResourceWarningr)r'Z_warnr.r.r/�__del__{s


zBaseSubprocessTransport.__del__c


Cs|jSr:)
rr>r.r.r/�get_pid�s
zBaseSubprocessTransport.get_pidc


Cs|jSr:)
rr>r.r.r/�get_returncode�s
z&BaseSubprocessTransport.get_returncodecCs|
|jvr|j|
j
SdSdSr:)rr5)r'�fdr.r.r/�get_pipe_transport�s


z*BaseSubprocessTransport.get_pipe_transportc

Cs|jdurt
��
dSr:)rrCr>r.r.r/�_check_proc�s


z#BaseSubprocessTransport._check_proccCs|��
|j
�|
�

dSr:)rLr�send_signal)r'�signalr.r.r/rM�s

z#BaseSubprocessTransport.send_signalc

Cs|��
|j
��
dSr:)rLr�	terminater>r.r.r/rO�s

z!BaseSubprocessTransport.terminatec

Cs|��
|j
��
dSr:)rLrrBr>r.r.r/rB�s

zBaseSubprocessTransport.killc	
�sr
z�j}�j
}|jdu
rB|��f
d
d�|j�IdH\}}|�jd<|jdu
rv|��f
dd�|j�IdH\}}|�jd<|jdu
r�|��f
dd�|j�IdH\}}|�jd<�jdu
s�J�
|�	�j
j��
�jD]\}}|j	|g
|�
R�
q�d�_Wn\tt
f�
y


�Ynbt�
yN
}
z*|
du
�
r:|
���
s:|
�|�

WYd}~n(d}~00|
du
�
rn|
���
sn|
�d�

dS)Ncs
t�d
�S)Nr
)
�WriteSubprocessPipeProtor.r>r.r/�<lambda>��z8BaseSubprocessTransport._connect_pipes.<locals>.<lambda>r
cs
t�d
�S)Nr�
�ReadSubprocessPipeProtor.r>r.r/rQ�rRrcs
t�d
�S)NrrSr.r>r.r/rQ�rRr)rrr
Zconnect_write_piperrZconnect_read_piperr�	call_soonr�connection_made�
SystemExit�KeyboardInterrupt�
BaseException�	cancelledZ
set_exception�
set_result)	r'r*�procr(�
_r5�callback�data�excr.r>r/r&�sB







�





�





�









 
z&BaseSubprocessTransport._connect_pipescGs4|jdu
r|j�
|
|f�

n|jj|
g
|�
R�
dSr:)rr3rrU)r'�cbr_r.r.r/�_call�s


zBaseSubprocessTransport._callcCs|�|j
j|
|�
|��
dSr:)rbrZpipe_connection_lost�_try_finish)r'rJr`r.r.r/�_pipe_connection_lost�s

z-BaseSubprocessTransport._pipe_connection_lostcCs|�|j
j|
|�
dSr:)rbrZpipe_data_received)r'rJr_r.r.r/�_pipe_data_received�s
z+BaseSubprocessTransport._pipe_data_receivedcCs�|
du
sJ|
�
�
|jdus$J|j�
�
|j
��r<t�d
||
�
|
|_|jjdurV|
|j_|�|jj	�

|�
�
|jD]}|��sr|�
|
�

qrd|_dS)Nz%r exited with return code %r)rrr!rr8r�
returncoderbrZprocess_exitedrcrrZr[)r'rfr*r.r.r/�_process_exited�s












z'BaseSubprocessTransport._process_exitedc
�s0|jd
u
r|jS|j
��}
|j�|
�

|
Id
HS)zdWait until the process exit and return the process return code.

        This method is a coroutine.N)rrZ
create_futurerr3)r'r*r.r.r/�_wait�s





zBaseSubprocessTransport._waitc

CsH|jr
J�
|j
durdStd
d�|j��D�
�
rDd|_|�|jd�
dS)Nc
ss|]}
|
du
o|
jV
qdSr:)
�disconnected)�.0�
pr.r.r/�	<genexpr>�s
�z6BaseSubprocessTransport._try_finish.<locals>.<genexpr>T)rr�allrrArb�_call_connection_lostr>r.r.r/rc�s






�
z#BaseSubprocessTransport._try_finishcCs<z"|j�
|
�

Wd|_d|_d|_nd|_d|_d|_0dSr:)r�connection_lostrr�r'r`r.r.r/rn�s



�

z-BaseSubprocessTransport._call_connection_lost)NN)r2�
__module__�__qualname__rr9rr=r?r@r�warnings�warnrGrHrIrKrLrMrOrBr&rbrdrergrhrcrn�
__classcell__r.r.r,r/r
s0�+&	rc@s<eZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
S)rPcCs|
|_||_
d|_d
|_dS)NF)r\rJr5ri)r'r\rJr.r.r/r

s



z!WriteSubprocessPipeProto.__init__cCs
|
|_dSr:)
r5)r'Z	transportr.r.r/rV
s
z(WriteSubprocessPipeProto.connection_madec

Cs d
|jj
�d|j�d|j�d�S)N�
<z fd=z pipe=�
>)r-r2rJr5r>r.r.r/r9

s
z!WriteSubprocessPipeProto.__repr__cCs d
|_|j
�|j|
�
d|_
dS)NT)rir\rdrJrpr.r.r/ro

s


z(WriteSubprocessPipeProto.connection_lostc

Cs|jj
��
dSr:)r\r�
pause_writingr>r.r.r/rx
s
z&WriteSubprocessPipeProto.pause_writingc

Cs|jj
��
dSr:)r\r�resume_writingr>r.r.r/ry
s
z'WriteSubprocessPipeProto.resume_writingN)	r2rqrrrrVr9rorxryr.r.r.r/rP�srPc@seZ
dZd
d�ZdS)rTcCs|j�
|j|
�
dSr:)r\rerJ)r'r_r.r.r/�
data_received
s
z%ReadSubprocessPipeProto.data_receivedN)r2rqrrrzr.r.r.r/rT
srT)rrrs�rr�logrZSubprocessTransportrZBaseProtocolrP�ProtocolrTr.r.r.r/�<module>
s



v
�