| Server IP : 162.19.112.25 / Your IP : 216.73.216.88 Web Server : LiteSpeed System : Linux qamar.tasjeel.ae 5.14.0-611.55.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue May 19 15:19:29 EDT 2026 x86_64 User : archiart ( 1428) PHP Version : 8.2.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /proc/self/root/opt/alt/python37/lib64/python3.7/asyncio/__pycache__/ |
Upload File : |
B
n��*U� � @ sx d dl Z d dlZd dlZddlmZ ddlmZ ddlmZ G dd� dej�Z G dd � d ej
�Z G d
d � d e ej �Z
dS ) � N� )� protocols)�
transports)�loggerc s� e Zd Zd0� fdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zd d � Zd d � 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< y"| jf ||||||d�| �� W n | �� � Y nX | jj| _| j| jd< | j�� �rt|ttf�r�|} n|d } t�d| | j� | j�| �| �� d S )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 �debugZ create_task�_connect_pipes)
�self�loop�protocolr r r
r r r
�waiterZextra�kwargsZprogram)� __class__� �</opt/alt/python37/lib64/python3.7/asyncio/base_subprocess.pyr s@
z BaseSubprocessTransport.__init__c C s | j jg}| jr|�d� | jd k r6|�d| j� �� | jd k rT|�d| j� �� n | jd k rj|�d� n
|�d� | j�d�}|d k r�|�d|j� �� | j�d�}| j�d �}|d k r�||kr�|�d
|j� �� n6|d k r�|�d |j� �� |d k �r |�d |j� �� d
� d�
|��S )N�closedzpid=z returncode=Zrunningz not startedr zstdin=r r zstdout=stderr=zstdout=zstderr=z<{}>� ) r, �__name__r �appendr r r �get�pipe�format�join)r' �infor
r r r- r- r. �__repr__7 s,
z BaseSubprocessTransport.__repr__c K s t �d S )N)�NotImplementedError)r' r r r
r r r
r+ r- r- r. r T s z BaseSubprocessTransport._startc C s
|| _ d S )N)r )r' r) r- r- r. � set_protocolW s z$BaseSubprocessTransport.set_protocolc C s | j S )N)r )r' r- r- r. � get_protocolZ s z$BaseSubprocessTransport.get_protocolc C s | j S )N)r )r' r- r- r. �
is_closing] s z"BaseSubprocessTransport.is_closingc C s� | j r
d S d| _ x&| j�� D ]}|d kr*q |j�� q W | jd k r�| jd kr�| j�� d kr�| j� � rpt
� d| � y| j� � W n t
k
r� Y nX d S )NTz$Close running child process: kill %r)r r �valuesr4 r r r Zpollr r! r Zwarning�kill�ProcessLookupError)r' �protor- r- r. r ` s
z BaseSubprocessTransport.closec C s( | j s$tjd| ��t| d� | �� d S )Nzunclosed transport )�source)r �warnings�warn�ResourceWarningr )r' r- r- r. �__del__{ s z BaseSubprocessTransport.__del__c C s | j S )N)r )r' r- r- r. �get_pid� s z BaseSubprocessTransport.get_pidc C s | j S )N)r )r' r- r- r. �get_returncode� s z&BaseSubprocessTransport.get_returncodec C s || j kr| j | jS d S d S )N)r r4 )r' �fdr- r- r. �get_pipe_transport� s
z*BaseSubprocessTransport.get_pipe_transportc C s | j d krt� �d S )N)r r? )r' r- r- r. � _check_proc� s
z#BaseSubprocessTransport._check_procc C s | � � | j�|� d S )N)rJ r � send_signal)r' �signalr- r- r. rK � s z#BaseSubprocessTransport.send_signalc C s | � � | j�� d S )N)rJ r � terminate)r' r- r- r. rM � s z!BaseSubprocessTransport.terminatec C s | � � | j�� d S )N)rJ r r> )r' r- r- r. r> � s z BaseSubprocessTransport.killc
� sZ y� j }� j}|jd k rB|�� fdd�|j�I d H \}}|� jd< |jd k rv|�� fdd�|j�I d H \}}|� jd< |jd k r�|�� fdd�|j�I d H \}}|� jd< � jd k s�t �|�
� j j � � x"� jD ]\}}|j
|f|�� q�W d � _W nB t
k
�r6 } z"|d k �r&|�� �s&|�|� W d d }~X Y n X |d k �rV|�� �sV|�d � d S )Nc s
t � d�S )Nr )�WriteSubprocessPipeProtor- )r' r- r. �<lambda>� � z8BaseSubprocessTransport._connect_pipes.<locals>.<lambda>r c s
t � d�S )Nr )�ReadSubprocessPipeProtor- )r' r- r. rO � rP r c s
t � d�S )Nr )rQ r- )r' r- r. rO � rP r )r r r
Zconnect_write_piper r Zconnect_read_piper r �AssertionError� call_soonr �connection_made� Exception� cancelledZ
set_exception�
set_result) r' r* �procr( �_r4 �callback�data�excr- )r' r. r& � s8
z&BaseSubprocessTransport._connect_pipesc G s2 | j d k r | j �||f� n| jj|f|�� d S )N)r r2 r rS )r' �cbr[ r- r- r. �_call� s
z BaseSubprocessTransport._callc C s | � | jj||� | �� d S )N)r^ r Zpipe_connection_lost� _try_finish)r' rH r\ r- r- r. �_pipe_connection_lost� s z-BaseSubprocessTransport._pipe_connection_lostc C s | � | jj||� d S )N)r^ r Zpipe_data_received)r' rH r[ r- r- r. �_pipe_data_received� s z+BaseSubprocessTransport._pipe_data_receivedc C s� |d k st |��| jd ks$t | j��| j�� r<t�d| |� || _| jjd krV|| j_| �| j j
� | � � x | j D ]}|�
� st|�|� qtW d | _ d S )Nz %r exited with return code %r)rR r r r! r r7 r �
returncoder^ r Zprocess_exitedr_ r rV rW )r' rb r* r- r- r. �_process_exited� s
z'BaseSubprocessTransport._process_exitedc � s0 | j dk r| j S | j�� }| j�|� |I dH S )zdWait until the process exit and return the process return code.
This method is a coroutine.N)r r Z
create_futurer r2 )r' r* r- r- r. �_wait� s
z BaseSubprocessTransport._waitc C sH | j r
t�| jd krd S tdd� | j�� D ��rDd| _ | �| jd � d S )Nc s s | ]}|d k o|j V qd S )N)� disconnected)�.0�pr- r- r. � <genexpr>� s z6BaseSubprocessTransport._try_finish.<locals>.<genexpr>T)r rR r �allr r= r^ �_call_connection_lost)r' r- r- r. r_ � s
z#BaseSubprocessTransport._try_finishc C s* z| j �|� W d d | _d | _d | _ X d S )N)r �connection_lostr r )r' r\ r- r- r. rj � s
z-BaseSubprocessTransport._call_connection_lost)NN)r1 �
__module__� __qualname__r r8 r r: r; r< r rE rF rG rI rJ rK rM r> r& r^ r` ra rc rd r_ rj �
__classcell__r- r- )r, r. r
s. ) $ r c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )rN c C s || _ || _d | _d| _d S )NF)rX rH r4 re )r' rX rH r- r- r. r s z!WriteSubprocessPipeProto.__init__c C s
|| _ d S )N)r4 )r' Z transportr- r- r. rT s z(WriteSubprocessPipeProto.connection_madec C s d| j j� d| j� d| j�d�S )N�<z fd=z pipe=�>)r, r1 rH r4 )r' r- r- r. r8 s z!WriteSubprocessPipeProto.__repr__c C s d| _ | j�| j|� d | _d S )NT)re rX r` rH )r' r\ r- r- r. rk s z(WriteSubprocessPipeProto.connection_lostc C s | j j�� d S )N)rX r �
pause_writing)r' r- r- r. rq s z&WriteSubprocessPipeProto.pause_writingc C s | j j�� d S )N)rX r �resume_writing)r' r- r- r. rr s z'WriteSubprocessPipeProto.resume_writingN) r1 rl rm r rT r8 rk rq rr r- r- r- r. rN � s rN c @ s e Zd Zdd� ZdS )rQ c C s | j �| j|� d S )N)rX ra rH )r' r[ r- r- r. �
data_received s z%ReadSubprocessPipeProto.data_receivedN)r1 rl rm rs r- r- r- r. rQ s rQ )r r rB � r r �logr ZSubprocessTransportr Z BaseProtocolrN ZProtocolrQ r- r- r- r. �<module> s u