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 ]

3

��2a��@s�dd
gZddl
Z
ddlmZ
ddlmZ
ddlmZ
ddlmZ
dd	lmZ
dd
l	m
Z

e
jZe
jZe
j
Z
Gdd�dejej�ZGd
d�d�Zeddddejfdd
�
�
Zeddddejd�dd��
ZdS)�create_subprocess_exec�create_subprocess_shell�N�
)
�events)
�	protocols)
�streams)
�tasks)
�	coroutine)
�loggercsLeZ
dZ�f
d
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	�Z
S)�SubprocessStreamProtocolcs<t�j
|d
�

|
|_d|_|_|_d|_d|_g|_dS)N)
�loopF)	�super�__init__�_limit�stdin�stdout�stderr�
_transport�_process_exited�	_pipe_fds)�self�limitr)
�	__class__��//opt/alt/python36/lib64/python3.6/subprocess.pyrs





z!SubprocessStreamProtocol.__init__c
Csf|jj
g
}
|jdk	r$|
jd
|j�

|jdk	r>|
jd|j�

|jdk	rX|
jd|j�

ddj|
�
S)Nzstdin=%rz	stdout=%rz	stderr=%rz<%s>�
 )r�__name__r�appendrr�join)r�inforrr�__repr__s











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

|jj	d
�

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

|jj	d�

|
j
d�
}|dk	r�tj||d|jd�|_dS)Nr)rr�r)�protocol�readerr)
r�get_pipe_transportr�StreamReaderr�_looprZ
set_transportrrr�StreamWriterr)r�	transportZstdout_transportZstderr_transportZstdin_transportrrr�connection_made(s&


















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

dS)Nrr!)rrZ	feed_data)r�fd�datar#rrr�pipe_data_received@s





z+SubprocessStreamProtocol.pipe_data_receivedcCs�|
d
kr,|j}|dk	r|j
�
|j|�

dS|
dkr<|j}n|
dkrL|j}nd}|dkrt|dkrj|j�
n
|j|�

|
|jkr�|jj|
�

|j	�
dS)Nrrr!)
r�closeZconnection_lostrrZfeed_eofZ
set_exceptionr�remove�_maybe_close_transport)rr*�exc�piper#rrr�pipe_connection_lostJs$


















z-SubprocessStreamProtocol.pipe_connection_lostc

Csd
|_|j
�
dS)NT)rr/)
rrrr�process_exitedas

z'SubprocessStreamProtocol.process_exitedc

Cs(t|j
�
d
kr$|jr$|jj�
d|_dS)Nr)�lenrrrr-)
rrrrr/es



z/SubprocessStreamProtocol._maybe_close_transport)r�
__module__�__qualname__rr r)r,r2r3r/�
__classcell__rr)
rrrs

rc@s~eZ
dZd
d�Zdd�Zedd��
Zedd��
Zd	d
�Z	dd�Z
d
d�Zedd��
Zedd��
Z
edd��
Zeddd�
�
ZdS)�ProcesscCs8|
|_||_
||_|j|_|j|_|j|_|
j�|_dS)
N)rZ	_protocolr&rrrZget_pid�pid)rr(r"rrrrrls






zProcess.__init__c

Csd
|jj
|jfS)Nz<%s %s>)rrr9)
rrrrr us
zProcess.__repr__c


Cs
|jj
�S)
N)rZget_returncode)
rrrr�
returncodexszProcess.returncodec

cs|jj
�EdHS)
N)rZ_wait)
rrrr�wait|szProcess.waitcCs|jj
|
�

dS)
N)r�send_signal)r�signalrrrr<�s
zProcess.send_signalc


Cs|jj
�
dS)
N)r�	terminate)
rrrrr>�s
zProcess.terminatec


Cs|jj
�
dS)
N)r�kill)
rrrrr?�s
zProcess.killccs�|jj
�}|jj|
�

|r,tjd
|t|
�
�
y|jj�EdH
Wn8tt	fk
rx
}
z|rhtjd||�
WYdd}~XnX|r�tjd|�
|jj
�
dS)Nz%%r communicate: feed stdin (%s bytes)z%r communicate: stdin got %rz%r communicate: close stdin)r&�	get_debugr�writer
�debugr4Zdrain�BrokenPipeError�ConnectionResetErrorr-)r�inputrBr0rrr�_feed_stdin�s








 

zProcess._feed_stdinc


CsdS)
Nr)
rrrr�_noop�sz
Process._noopccs�|jj
|
�
}|
d
kr|j}n|j}|jj�rJ|
dkr8dnd}tjd||�
|j�EdH}|jj�r�|
dkrndnd}tjd||�
|j	�
|S)Nr!rrrz%r communicate: read %sz%r communicate: close %s)
rr$rrr&r@r
rB�readr-)rr*r(�stream�name�outputrrr�_read_stream�s












zProcess._read_streamNccs�|
dk	r|j|
�
}n|j
�}|jdk	r2|jd
�
}n|j
�}|jdk	rP|jd�
}n|j
�}tj||||jd�EdH\}}}|j�EdH
||fS)Nrr!)
r)	rFrGrrLrrZgatherr&r;)rrErrrrrr�communicate�s











zProcess.communicate)
N)rr5r6rr �propertyr:r	r;r<r>r?rFrGrLrMrrrrr8ks
	
r8c
+sP�
dkrtj
��
��
fd
d�}�
j||f|
||d�|��
EdH\}}	t||	�
�S)Ncst��
d
�S)N)rr)
rr)rrrr�<lambda>�s
z)create_subprocess_shell.<locals>.<lambda>)rrr)r�get_event_loopZsubprocess_shellr8)
�cmdrrrrr�kwds�protocol_factoryr(r"r)rrrr�s





)rrrrrc
/sT�
dkrtj
��
��
fd
d�}�
j||f|�|
||d�|��
EdH\}	}
t|	|
�
�S)Ncst��
d
�S)N)rr)
rr)rrrrrO�s
z(create_subprocess_exec.<locals>.<lambda>)rrr)rrPZsubprocess_execr8)Zprogramrrrrr�argsrRrSr(r"r)rrrr
�s






)�__all__�
subprocess�rrrrZ
coroutinesr	�logr
�PIPEZSTDOUTZDEVNULLZFlowControlMixinZSubprocessProtocolrr8Z_DEFAULT_LIMITrr
rrrr�<module>
s(







X]