0x1949 Team - FAZEMRX - MANAGER
Edit File: base_subprocess.cpython-310.pyc
o ��+g�" � @ 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 Z d0� fdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zdd� Z e j fdd�Z dd� Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Z� Z S )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�| �� W n | �� � | jj| _| j| jd< | j�� r�t|ttf�rx|} 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�pid�_extra� get_debug� isinstance�bytes�strr �debug� create_task�_connect_pipes) �self�loop�protocolr r r r r r �waiter�extra�kwargs�program�� __class__r �./usr/lib/python3.10/asyncio/base_subprocess.pyr sH � � �z BaseSubprocessTransport.__init__c C s | j jg}| jr |�d� | jd ur|�d| j� �� | jd ur*|�d| j� �� n| jd ur5|�d� n|�d� | j�d�}|d urM|�d|j� �� | j�d�}| j�d �}|d urk||u rk|�d |j� �� n|d urx|�d |j� �� |d ur�|�d |j� �� d � d� |��S )N�closedzpid=z returncode=�runningz not startedr zstdin=r r zstdout=stderr=zstdout=zstderr=z<{}>� ) r2 �__name__r �appendr r r �get�pipe�format�join)r* �infor r r r r r3 �__repr__7 s, z BaseSubprocessTransport.__repr__c K s t ��N)�NotImplementedError)r* r r r r r r r/ r r r3 r T s z BaseSubprocessTransport._startc C � || _ d S r? �r )r* r, r r r3 � set_protocolW � z$BaseSubprocessTransport.set_protocolc C � | j S r? rB �r* r r r3 � get_protocolZ � z$BaseSubprocessTransport.get_protocolc C rE r? )r rF r r r3 � is_closing] rH z"BaseSubprocessTransport.is_closingc C s� | j rd S d| _ | j�� D ] }|d u rq |j�� q | jd urI| jd u rK| j�� d u rM| j� � r6t � d| � z| j� � W d S t yH Y d S w d S d S d S )NTz$Close running child process: kill %r)r r �valuesr: r r r �pollr r# r �warning�kill�ProcessLookupError)r* �protor r r3 r ` s( ��z BaseSubprocessTransport.closec C s* | j s|d| ��t| d� | �� d S d S )Nzunclosed transport )�source)r �ResourceWarningr )r* �_warnr r r3 �__del__{ s �z BaseSubprocessTransport.__del__c C rE r? )r rF r r r3 �get_pid� rH z BaseSubprocessTransport.get_pidc C rE r? )r rF r r r3 �get_returncode� rH z&BaseSubprocessTransport.get_returncodec C s || j v r | j | jS d S r? )r r: )r* �fdr r r3 �get_pipe_transport� s z*BaseSubprocessTransport.get_pipe_transportc C s | j d u rt� �d S r? )r rN rF r r r3 � _check_proc� s �z#BaseSubprocessTransport._check_procc C s | � � | j�|� d S r? )rX r � send_signal)r* �signalr r r3 rY � s z#BaseSubprocessTransport.send_signalc C � | � � | j�� d S r? )rX r � terminaterF r r r3 r\ � � z!BaseSubprocessTransport.terminatec C r[ r? )rX r rM rF r r r3 rM � r] z BaseSubprocessTransport.killc � s� �zy� j }� j}|jd ur"|�� fdd�|j�I d H \}}|� jd< |jd ur<|�� fdd�|j�I d H \}}|� jd< |jd urV|�� fdd�|j�I d H \}}|� jd< � jd us]J �|� � j j � � � jD ] \}}|j |g|�R � qhd � _W n7 t t fy� � ty� } z"|d ur�|�� s�|�|� W Y d }~d S W Y d }~d S W Y d }~d S d }~ww |d ur�|�� s�|�d � d S d S d S )Nc � t � d�S )Nr )�WriteSubprocessPipeProtor rF r r3 �<lambda>� � z8BaseSubprocessTransport._connect_pipes.<locals>.<lambda>r c r^ )Nr ��ReadSubprocessPipeProtor rF r r3 r` � ra r c r^ )Nr rb r rF r r3 r` � ra r )r r r �connect_write_piper r �connect_read_piper r � call_soonr �connection_made� SystemExit�KeyboardInterrupt� BaseException� cancelled� set_exception� set_result) r* r- �procr+ �_r: �callback�data�excr rF r3 r) � sL � � � � ����z&BaseSubprocessTransport._connect_pipesc G s6 | j d ur| j �||f� d S | jj|g|�R � d S r? )r r8 r rf )r* �cbrq r r r3 �_call� s z BaseSubprocessTransport._callc C s | � | jj||� | �� d S r? )rt r �pipe_connection_lost� _try_finish)r* rV rr r r r3 �_pipe_connection_lost� s z-BaseSubprocessTransport._pipe_connection_lostc C s | � | jj||� d S r? )rt r �pipe_data_received)r* rV rq r r r3 �_pipe_data_received� s z+BaseSubprocessTransport._pipe_data_receivedc C s� |d usJ |��| j d u sJ | j ��| j�� r t�d| |� || _ | jjd u r+|| j_| �| jj � | � � | j D ] }|� � sD|� |� q9d | _ d S )Nz %r exited with return code %r)r r r# r r= r � returncodert r �process_exitedrv r rk rm )r* rz r- r r r3 �_process_exited� s � z'BaseSubprocessTransport._process_exitedc � s2 �| j dur | 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 � create_futurer r8 )r* r- r r r3 �_wait� s � z BaseSubprocessTransport._waitc C sL | j rJ �| jd u r d S tdd� | j�� D ��r$d| _ | �| jd � d S d S )Nc s s � | ] }|d uo |j V qd S r? )� disconnected)�.0�pr r r3 � <genexpr>� s � �z6BaseSubprocessTransport._try_finish.<locals>.<genexpr>T)r r �allr rJ rt �_call_connection_lostrF r r r3 rv � s ��z#BaseSubprocessTransport._try_finishc C s: z| j �|� W d | _d | _d | _ d S d | _d | _d | _ w r? )r �connection_lostr r �r* rr r r r3 r� � s �z-BaseSubprocessTransport._call_connection_lost)NN) r7 � __module__� __qualname__r r> r rC rG rI r �warnings�warnrS rT rU rW rX rY r\ rM r) rt rw ry r| r~ rv r� � __classcell__r r r1 r3 r s2 �+ & r c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )r_ c C s || _ || _d | _d| _d S )NF)rn rV r: r )r* rn rV r r r3 r s z!WriteSubprocessPipeProto.__init__c C rA r? )r: )r* � transportr r r3 rg rD z(WriteSubprocessPipeProto.connection_madec C s d| j j� d| j� d| j�d�S )N�<z fd=z pipe=�>)r2 r7 rV r: rF r r r3 r> s z!WriteSubprocessPipeProto.__repr__c C s d| _ | j�| j|� d | _d S )NT)r rn rw rV r� r r r3 r� s z(WriteSubprocessPipeProto.connection_lostc C � | j j�� d S r? )rn r � pause_writingrF r r r3 r� � z&WriteSubprocessPipeProto.pause_writingc C r� r? )rn r �resume_writingrF r r r3 r� r� z'WriteSubprocessPipeProto.resume_writingN) r7 r� r� r rg r> r� r� r� r r r r3 r_ � s r_ c @ s e Zd Zdd� ZdS )rc c C s | j �| j|� d S r? )rn ry rV )r* rq r r r3 � data_received s z%ReadSubprocessPipeProto.data_receivedN)r7 r� r� r� r r r r3 rc s rc )r r r� � r r �logr �SubprocessTransportr � BaseProtocolr_ �Protocolrc r r r r3 �<module> s v �