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��@s�dZd
dl
Z
d
dlZddlmZ
ddlmZ
ddlmZ
ddlmZ
ddlm	Z	
e
j
Z
e
jZe
jZGd	d
�d
ej
ej�ZGdd�d�Zddddejfd
d�
Zddddejd�dd�ZdS))�create_subprocess_exec�create_subprocess_shell�N�
)
�events)
�	protocols)
�streams)
�tasks)
�loggercsXeZ
dZd
Z�f
dd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
dd�Z�ZS)�SubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.csHt�j
|d
�

|
|_d|_|_|_d|_d|_g|_|j	�
�|_dS)N�
�loopF)�super�__init__�_limit�stdin�stdout�stderr�
_transport�_process_exited�	_pipe_fds�_loopZ
create_future�
_stdin_closed)�self�limitr�
�	__class__��7/opt/alt/python39/lib64/python3.9/asyncio/subprocess.pyrs






z!SubprocessStreamProtocol.__init__c
Csn|jj
g
}
|jdu
r&|
�d
|j���

|jdu
rB|
�d|j���

|jdu
r^|
�d|j���

d�d�|
�
�
S)Nzstdin=zstdout=zstderr=z<{}>�
 )r�__name__r�appendrr�format�join)r�inforrr�__repr__s











z!SubprocessStreamProtocol.__repr__cCs�|
|_|
�
d
�
}|du
rDtj|j|jd�|_|j�|�

|j�	d
�

|
�
d�
}|du
r�tj|j|jd�|_
|j
�|�

|j�	d�

|
�
d�
}|du
r�tj||d|jd�|_dS)Nr�rr�r)�protocol�readerr)
r�get_pipe_transportr�StreamReaderrrrZ
set_transportrr r�StreamWriterr)r�	transportZstdout_transportZstderr_transportZstdin_transportrrr�connection_made)s,




�




�






�z(SubprocessStreamProtocol.connection_madecCs:|
d
kr|j}n|
dkr |j
}nd}|du
r6|�|�

dS)Nrr&)rrZ	feed_data)r�fd�datar(rrr�pipe_data_receivedAs





z+SubprocessStreamProtocol.pipe_data_receivedcCs�|
d
krN|j}|du
r|�
�
|�|�

|dur>|j�d�

n|j�|�

dS|
dkr^|j}n|
dkrn|j}nd}|du
r�|dur�|��
n
|�|�

|
|j	vr�|j	�
|
�

|��
dS)Nrrr&)r�closeZconnection_lostrZ
set_resultZ
set_exceptionrrZfeed_eofr�remove�_maybe_close_transport)rr.�exc�piper(rrr�pipe_connection_lostKs*




















z-SubprocessStreamProtocol.pipe_connection_lostc

Csd
|_|�
�
dS)NT)rr3�
rrrr�process_exitedfs

z'SubprocessStreamProtocol.process_exitedc

Cs(t|j
�
d
kr$|jr$|j��
d|_dS)Nr)�lenrrrr1r7rrrr3js



z/SubprocessStreamProtocol._maybe_close_transportcCs|
|jur|j
SdS�
N)rr)r�streamrrr�_get_close_waiteros


z*SubprocessStreamProtocol._get_close_waiter)
r�
__module__�__qualname__�__doc__rr$r-r0r6r8r3r<�
__classcell__rrrrr
s	

r
c@sjeZ
dZd
d�Zdd�Zedd��
Zdd�Zd	d
�Zdd�Z	d
d�Z
dd�Zdd�Zdd�Z
ddd�
ZdS)�ProcesscCs8|
|_||_
||_|j|_|j|_|j|_|
��|_dSr:)rZ	_protocolrrrrZget_pid�pid)rr,r'rrrrrus






zProcess.__init__c

Csd
|jj
�d|j�d�S)N�
<r�
>)rrrBr7rrrr$~s
zProcess.__repr__c

Cs
|j�
�Sr:)rZget_returncoder7rrr�
returncode�szProcess.returncodec

�s|j�
�Id
HS)z?Wait until the process exit and return the process return code.N)rZ_waitr7rrr�wait�szProcess.waitcCs|j�
|
�

dSr:)r�send_signal)r�signalrrrrG�s
zProcess.send_signalc

Cs|j�
�
dSr:)r�	terminater7rrrrI�s
zProcess.terminatec

Cs|j�
�
dSr:)r�killr7rrrrJ�s
zProcess.killc
�s�|j�
�}|j�|
�

|r,t�d
|t|
�
�
z|j��IdH
Wn:tt	fyz
}
z|rft�d||�
WYd}~n
d}~00|r�t�d|�
|j�
�
dS)Nz%%r communicate: feed stdin (%s bytes)z%r communicate: stdin got %rz%r communicate: close stdin)r�	get_debugr�writer	�debugr9Zdrain�BrokenPipeError�ConnectionResetErrorr1)r�inputrMr4rrr�_feed_stdin�s






�


$

zProcess._feed_stdinc


�sdSr:rr7rrr�_noop�s
z
Process._noopc�s�|j�
|
�
}|
d
kr|j}n|
dks(J�
|j}|j��rV|
dkrDdnd}t�d||�
|��IdH}|j��r�|
dkrzdnd}t�d||�
|�	�
|S)Nr&rrrz%r communicate: read %sz%r communicate: close %s)
rr)rrrrKr	rM�readr1)rr.r,r;�name�outputrrr�_read_stream�s














zProcess._read_streamNc�s�|
du
r|�|
�
}n|�
�}|jdu
r2|�d
�
}n|�
�}|jdu
rP|�d�
}n|�
�}tj||||jd�IdH\}}}|��IdH
||fS)Nrr&r)	rQrRrrVrrZ_gatherrrF)rrPrrrrrr�communicate�s










�
zProcess.communicate)
N)rr=r>rr$�propertyrErFrGrIrJrQrRrVrWrrrrrAts
	

rAc
�sb�
durt�
��
ntjd
tdd�
��
fdd�}�
j||f|
||d�|�
�
IdH\}}	t||	�
�S)N�ZThe loop argument is deprecated since Python 3.8 and scheduled for removal in Python 3.10.r&�
�
stacklevelcst��
d
�S�Nr%�
r
rr%rr�<lambda>�s
�z)create_subprocess_shell.<locals>.<lambda>�rrr)r�get_event_loop�warnings�warn�DeprecationWarningZsubprocess_shellrA)
�cmdrrrrr�kwds�protocol_factoryr,r'rr%rr�s"


�

�
��r)rrrrrc
�sh�
durt�
��
ntjd
tdd�
��
fdd�}�
j||g|�
R|
||d�|�
�
IdH\}	}
t|	|
�
�S)NrYr&rZcst��
d
�Sr\r]rr%rrr^�s
�z(create_subprocess_exec.<locals>.<lambda>r_)rr`rarbrcZsubprocess_execrA)Zprogramrrrrr�argsrerfr,r'rr%rr
�s&


�

��
��r
)�__all__�
subprocessra�rrrr�logr	�PIPEZSTDOUTZDEVNULLZFlowControlMixinZSubprocessProtocolr
rAZ_DEFAULT_LIMITrr
rrrr�<module>
s*







�bV
�


�