File: //usr/libexec/oracle-cloud-agent/plugins/osms/asyncio/base_subprocess.pyc
a
���d�" � @ 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 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| _
|tjkr`d | j d< |tjkrtd | j d< |tjkr�d | j d< z"| jf ||||||d�| �� W n | �� � Y n0 | 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�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__� �//usr/lib64/python3.9/asyncio/base_subprocess.pyr sH
��
�z BaseSubprocessTransport.__init__c C s | j jg}| jr|�d� | jd ur6|�d| j� �� | jd urT|�d| j� �� n | jd urj|�d� n
|�d� | j�d�}|d ur�|�d|j� �� | j�d�}| j�d �}|d ur�||u r�|�d
|j� �� n6|d ur�|�d |j� �� |d u�r |�d |j� �� d
� d�
|��S )N�closedzpid=z returncode=�runningz not startedr zstdin=r r zstdout=stderr=zstdout=zstderr=z<{}>� ) r1 �__name__r �appendr r r �get�pipe�format�join)r) �infor
r r r2 r2 r3 �__repr__7 s,
z BaseSubprocessTransport.__repr__c K s t �d S �N)�NotImplementedError)r) r r r
r r r
r. r2 r2 r3 r T s z BaseSubprocessTransport._startc C s
|| _ d S r? �r )r) r+ r2 r2 r3 � set_protocolW s z$BaseSubprocessTransport.set_protocolc C s | j S r? rA �r) r2 r2 r3 � get_protocolZ s z$BaseSubprocessTransport.get_protocolc C s | j S r? )r rC r2 r2 r3 �
is_closing] s z"BaseSubprocessTransport.is_closingc C s� | j r
d S d| _ | j�� D ]}|d u r(q|j�� q| jd ur�| jd u r�| j�� d u r�| j� � rlt
� d| � z| j� � W n t
y� Y n0 d S )NTz$Close running child process: kill %r)r r �valuesr: r r r �pollr r" r �warning�kill�ProcessLookupError)r) �protor2 r2 r3 r ` s$
� �
z BaseSubprocessTransport.closec C s& | j s"|d| ��t| d� | �� d S )Nzunclosed transport )�source)r �ResourceWarningr )r) �_warnr2 r2 r3 �__del__{ s z BaseSubprocessTransport.__del__c C s | j S r? )r rC r2 r2 r3 �get_pid� s z BaseSubprocessTransport.get_pidc C s | j S r? )r rC r2 r2 r3 �get_returncode� s z&BaseSubprocessTransport.get_returncodec C s || j v r| j | jS d S d S r? )r r: )r) �fdr2 r2 r3 �get_pipe_transport� s
z*BaseSubprocessTransport.get_pipe_transportc C s | j d u rt� �d S r? )r rJ rC r2 r2 r3 � _check_proc� s
z#BaseSubprocessTransport._check_procc C s | � � | j�|� d S r? )rT r � send_signal)r) �signalr2 r2 r3 rU � s z#BaseSubprocessTransport.send_signalc C s | � � | j�� d S r? )rT r � terminaterC r2 r2 r3 rW � s z!BaseSubprocessTransport.terminatec C s | � � | j�� d S r? )rT r rI rC r2 r2 r3 rI � s z BaseSubprocessTransport.killc
� sr z� j }� j}|jd urB|�� fdd�|j�I d H \}}|� jd< |jd urv|�� fdd�|j�I d H \}}|� jd< |jd ur�|�� fdd�|j�I d H \}}|� jd< � jd us�J �|� � j
j � � � jD ]\}}|j |g|�R � q�d � _W n\ t t
f�y � Y nb t�yN } z*|d u�r:|�� �s:|�|� W Y d }~n(d }~0 0 |d u�rn|�� �sn|�d � d S )Nc s
t � d�S )Nr )�WriteSubprocessPipeProtor2 rC r2 r3 �<lambda>� � z8BaseSubprocessTransport._connect_pipes.<locals>.<lambda>r c s
t � d�S )Nr ��ReadSubprocessPipeProtor2 rC r2 r3 rY � rZ r c s
t � d�S )Nr r[ r2 rC r2 r3 rY � rZ 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�excr2 rC r3 r( � sB
�
�
�
z&BaseSubprocessTransport._connect_pipesc G s4 | j d ur | j �||f� n| jj|g|�R � d S r? )r r8 r r_ )r) �cbrj r2 r2 r3 �_call� s
z BaseSubprocessTransport._callc C s | � | jj||� | �� d S r? )rm r �pipe_connection_lost� _try_finish)r) rR rk r2 r2 r3 �_pipe_connection_lost� s z-BaseSubprocessTransport._pipe_connection_lostc C s | � | jj||� d S r? )rm r �pipe_data_received)r) rR rj r2 r2 r3 �_pipe_data_received� s z+BaseSubprocessTransport._pipe_data_receivedc C s� |d usJ |��| j d u s$J | j ��| j�� r<t�d| |� || _ | jjd u rV|| j_| �| jj � | �
� | j D ]}|� � sr|�
|� qrd | _ d S )Nz %r exited with return code %r)r r r" r r= r �
returncoderm r �process_exitedro r rd rf )r) rs r, r2 r2 r3 �_process_exited� s
z'BaseSubprocessTransport._process_exitedc � s0 | 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, r2 r2 r3 �_wait� s
z BaseSubprocessTransport._waitc C sH | j r
J �| jd u rd S tdd� | j�� D ��rDd| _ | �| jd � d S )Nc s s | ]}|d uo|j V qd S r? )� disconnected)�.0�pr2 r2 r3 � <genexpr>� s �z6BaseSubprocessTransport._try_finish.<locals>.<genexpr>T)r r �allr rF rm �_call_connection_lostrC r2 r2 r3 ro � s
�z#BaseSubprocessTransport._try_finishc C s< z"| j �|� W d | _d | _d | _ nd | _d | _d | _ 0 d S r? )r �connection_lostr r �r) rk r2 r2 r3 r} � s �z-BaseSubprocessTransport._call_connection_lost)NN) r7 �
__module__� __qualname__r r> r rB rD rE r �warnings�warnrO rP rQ rS rT rU rW rI r( rm rp rr ru rw ro r} �
__classcell__r2 r2 r0 r3 r
s0 �+ & r c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )rX c C s || _ || _d | _d| _d S )NF)rg rR r: rx )r) rg rR r2 r2 r3 r s z!WriteSubprocessPipeProto.__init__c C s
|| _ d S r? )r: )r) � transportr2 r2 r3 r` s z(WriteSubprocessPipeProto.connection_madec C s d| j j� d| j� d| j�d�S )N�<z fd=z pipe=�>)r1 r7 rR r: rC r2 r2 r3 r>
s z!WriteSubprocessPipeProto.__repr__c C s d| _ | j�| j|� d | _d S )NT)rx rg rp rR r r2 r2 r3 r~
s z(WriteSubprocessPipeProto.connection_lostc C s | j j�� d S r? )rg r �
pause_writingrC r2 r2 r3 r� s z&WriteSubprocessPipeProto.pause_writingc C s | j j�� d S r? )rg r �resume_writingrC r2 r2 r3 r� s z'WriteSubprocessPipeProto.resume_writingN) r7 r� r� r r` r> r~ r� r� r2 r2 r2 r3 rX � s rX c @ s e Zd Zdd� ZdS )r\ c C s | j �| j|� d S r? )rg rr rR )r) rj r2 r2 r3 �
data_received s z%ReadSubprocessPipeProto.data_receivedN)r7 r� r� r� r2 r2 r2 r3 r\ s r\ )r r r� � r r �logr �SubprocessTransportr � BaseProtocolrX �Protocolr\ r2 r2 r2 r3 �<module> s v �