File: //proc/self/root/lib/python3/dist-packages/twisted/internet/__pycache__/_posixstdio.cpython-38.pyc
U
��W[O � @ sx d Z ddlmZ ddlmZmZmZ ddlmZm Z eej
�G dd� de ��Z eej
ejejej�G dd� de ��Zd S )
z�Standard input/out/err support.
Future Plans::
support for stderr, perhaps
Rewrite to use the reactor instead of an ad-hoc mechanism for connecting
protocols to transport.
Maintainer: James Y Knight
� )� implementer)�process�error�
interfaces)�log�failurec @ s e Zd ZdS )� PipeAddressN)�__name__�
__module__� __qualname__� r r �>/usr/lib/python3/dist-packages/twisted/internet/_posixstdio.pyr s r c @ s� e Zd ZdZdZdZdZd+dd�Zdd� Zd d
� Z d d � Z
d
d� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� ZdS ),�
StandardIONFr � c C sX |d krddl m} || _t�|| d|�| _t�|| d|�| _| j�� | j� | � d S )Nr )�reactor�write�read)
�twisted.internetr �protocolr Z
ProcessWriter�_writerZ
ProcessReader�_reader� startReadingZmakeConnection)�self�proto�stdin�stdoutr r r r
�__init__" s
zStandardIO.__init__c C s | j d k r| j �� d S �N)r �loseConnection�r r r r
�loseWriteConnection/ s
z StandardIO.loseWriteConnectionc C s | j d k r| j �|� d S r )r r �r �datar r r
r 3 s
zStandardIO.writec C s | j d k r| j �|� d S r )r �
writeSequencer! r r r
r# 7 s
zStandardIO.writeSequencec C s2 d| _ | jd k r| j�� | jd k r.| j�� d S �NT)�
disconnectingr r r � stopReadingr r r r
r ; s
zStandardIO.loseConnectionc C s t � S r �r r r r r
�getPeerD s zStandardIO.getPeerc C s t � S r r' r r r r
�getHostG s zStandardIO.getHostc C s | j �|� d S r )r Z dataReceived)r �fdr" r r r
�childDataReceivedL s z StandardIO.childDataReceivedc C sF | j r
d S |jjtjkr8|dkr,| �|� qB| �|� n
| �|� d S )Nr )� disconnected�value� __class__r ZConnectionDone�_readConnectionLost�_writeConnectionLost�connectionLost)r r* �reasonr r r
�childConnectionLostO s z StandardIO.childConnectionLostc C s� d| _ | j}| j}| j}d | _| _d | _|d k rB|j sB|�|� |d k rZ|j sZ|�|� z|�|� W n t�� Y nX d S r$ )r, r r r r1 r �err)r r2 r r r r r r
r1 \ s
zStandardIO.connectionLostc C s` d | _ | jr| �|� d S t�| jd �}|r\z |�� W n" t�� | �t �
� � Y nX d S r ) r r% r1 r �IHalfCloseableProtocolr ZwriteConnectionLostr r4 r �Failure�r r2 �pr r r
r0 q s
z StandardIO._writeConnectionLostc C sX d | _ t�| jd �}|rJz |�� W qT t�� | �t� � � Y qTX n
| �|� d S r )
r r r5 r ZreadConnectionLostr r4 r1 r r6 r7 r r r
r/ s z StandardIO._readConnectionLostc C s& | j d kr|�� n| j �||� d S r )r �
stopProducing�registerProducer)r ZproducerZ streamingr r r
r: � s
zStandardIO.registerProducerc C s | j d k r| j �� d S r )r �unregisterProducerr r r r
r; � s
z StandardIO.unregisterProducerc C s | � � d S r )r r r r r
r9 � s zStandardIO.stopProducingc C s | j d k r| j �� d S r )r �pauseProducingr r r r
r< � s
zStandardIO.pauseProducingc C s | j d k r| j �� d S r )r �resumeProducingr r r r
r= � s
zStandardIO.resumeProducingc C s | � � dS )z3Compatibility only, don't use. Call pauseProducing.N)r< r r r r
r& � s zStandardIO.stopReadingc C s | � � dS )z4Compatibility only, don't use. Call resumeProducing.N)r= r r r r
r � s zStandardIO.startReading)r r N)r r
r r r r, r% r r r r# r r( r) r+ r3 r1 r0 r/ r: r; r9 r< r= r& r r r r r
r s.
r N)�__doc__Zzope.interfacer r r r r Ztwisted.pythonr r ZIAddress�objectr Z
ITransportZ IProducerZ IConsumerZIHalfCloseableDescriptorr r r r r
�<module> s
�