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 ]

o

�=?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
dZ	
d0�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
|_
|tjkr0d|jd<|tjkr:d|jd<|tjkrDd|jd<z|jd||||||d�|�
�

Wn


|��
�|jj|_|j|jd<|j��r�t|ttf�rx|}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__r�>/opt/alt/python310/lib64/python3.10/asyncio/base_subprocess.pyrsH























�

�








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

|jdu
r|
�d|j���

|jdu
r*|
�d|j���

n|jdu
r5|
�d�

n|
�d�

|j�d�
}|du
rM|
�d|j���

|j�d�
}|j�d	�
}|du
rk||urk|
�d
|j���

n|du
rx|
�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rrr/�__repr__7s,






















z BaseSubprocessTransport.__repr__c
Kst�
�
N)
�NotImplementedError)r(rr	r
rrr
r,rrr/rTs
zBaseSubprocessTransport._startcC�
|
|_dSr:�
r)r(r*rrr/�set_protocolW�

z$BaseSubprocessTransport.set_protocolc


C�|jSr:r=�
r(rrr/�get_protocolZ�
z$BaseSubprocessTransport.get_protocolc


Cr@r:)
rrArrr/�
is_closing]rCz"BaseSubprocessTransport.is_closingc
Cs�|jrdSd
|_|j
��D]}
|
durq
|
j��
q
|jdu
rI|jdurK|j��durM|j�	�r6t
�d|�
z|j��
WdSt
yH


YdSwdSdSdS)NTz$Close running child process: kill %r)rr�valuesr5r rrZpollrr"rZwarning�kill�ProcessLookupError)r(�protorrr/r `s(












��zBaseSubprocessTransport.closecCs*|js|
d
|��t
|d�
|��
dSdS)Nzunclosed transport )
�source)r�ResourceWarningr )r(Z_warnrrr/�__del__{s


�zBaseSubprocessTransport.__del__c


Cr@r:)
rrArrr/�get_pid�rCzBaseSubprocessTransport.get_pidc


Cr@r:)
rrArrr/�get_returncode�rCz&BaseSubprocessTransport.get_returncodecCs|
|jvr|j|
j
SdSr:)rr5)r(�fdrrr/�get_pipe_transport�s


z*BaseSubprocessTransport.get_pipe_transportc

Cs|jdurt
��
dSr:)rrGrArrr/�_check_proc�s


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

dSr:)rPr�send_signal)r(�signalrrr/rQ�s

z#BaseSubprocessTransport.send_signalc

C�|��
|j
��
dSr:)rPr�	terminaterArrr/rT��

z!BaseSubprocessTransport.terminatec

CrSr:)rPrrFrArrr/rF�rUzBaseSubprocessTransport.killc	
�s�
�
zy�j}�j
}|jdu
r"|��f
d
d�|j�IdH\}}|�jd<|jdu
r<|��f
dd�|j�IdH\}}|�jd<|jdu
rV|��f
dd�|j�IdH\}}|�jd<�jdu
s]J�
|�	�j
j��
�jD]
\}}|j	|g
|�
R�
qhd�_Wn7tt
fy�


�ty�
}
z"|
du
r�|
��s�|
�|�

WYd}~dSWYd}~dSWYd}~dSd}~w
w|
du
r�|
��s�|
�d�

dSdSdS)Nc�
t�d
�S)Nr
)
�WriteSubprocessPipeProtorrArr/�<lambda>��
z8BaseSubprocessTransport._connect_pipes.<locals>.<lambda>r
crV)Nr�
�ReadSubprocessPipeProtorrArr/rX�rYrcrV)NrrZrrArr/rX�rYr)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�excrrAr/r'�sL�







�





�





�









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

dS|jj|
g
|�
R�
dSr:)rr3rr\)r(�cbrfrrr/�_call�s


zBaseSubprocessTransport._callcCs|�|j
j|
|�
|��
dSr:)rirZpipe_connection_lost�_try_finish)r(rNrgrrr/�_pipe_connection_lost�s

z-BaseSubprocessTransport._pipe_connection_lostcCs|�|j
j|
|�
dSr:)rirZpipe_data_received)r(rNrfrrr/�_pipe_data_received�s
z+BaseSubprocessTransport._pipe_data_receivedcCs�|
du
sJ|
�
�
|jdusJ|j�
�
|j
��rt�d
||
�
|
|_|jjdur+|
|j_|�|jj	�

|�
�
|jD]}|��sD|�
|
�

q9d|_dS)Nz%r exited with return code %r)rrr"rr8r�
returncoderirZprocess_exitedrjrrarb)r(rmr+rrr/�_process_exited�s












�

z'BaseSubprocessTransport._process_exitedc
�s2�
|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+rrr/�_wait�s�





zBaseSubprocessTransport._waitc

CsL|jrJ�
|j
durdStd
d�|j��D�
�
r$d|_|�|jd�
dSdS)Nc
ss�|]
}
|
du
o
|
jV
qdSr:)
�disconnected)�.0�
prrr/�	<genexpr>�s�
�z6BaseSubprocessTransport._try_finish.<locals>.<genexpr>T)rr�allrrEri�_call_connection_lostrArrr/rj�s






�
�z#BaseSubprocessTransport._try_finishcCs:z|j�
|
�

Wd|_d|_d|_dSd|_d|_d|_wr:)r�connection_lostrr�r(rgrrr/ru�s




�

z-BaseSubprocessTransport._call_connection_lost)NN)r2�
__module__�__qualname__rr9rr>rBrDr �warnings�warnrKrLrMrOrPrQrTrFr'rirkrlrnrorjru�
__classcell__rrr-r/r
s2�+&	rc@s<eZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
S)rWcCs|
|_||_
d|_d
|_dS)NF)rcrNr5rp)r(rcrNrrr/r

s




z!WriteSubprocessPipeProto.__init__cCr<r:)
r5)r(Z	transportrrr/r]
r?z(WriteSubprocessPipeProto.connection_madec

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

s 
z!WriteSubprocessPipeProto.__repr__cCs d
|_|j
�|j|
�
d|_
dS)NT)rprcrkrNrwrrr/rv

s



z(WriteSubprocessPipeProto.connection_lostc

C�|jj
��
dSr:)rcr�
pause_writingrArrr/r�
�
z&WriteSubprocessPipeProto.pause_writingc

Crr:)rcr�resume_writingrArrr/r�
r�z'WriteSubprocessPipeProto.resume_writingN)	r2rxryrr]r9rvr�r�rrrr/rW�srWc@seZ
dZd
d�ZdS)r[cCs|j�
|j|
�
dSr:)rcrlrN)r(rfrrr/�
data_received
s
z%ReadSubprocessPipeProto.data_receivedN)r2rxryr�rrrr/r[
sr[)rrrz�rr�logrZSubprocessTransportrZBaseProtocolrWZProtocolr[rrrr/�<module>
s



v
�