← Back
Editing: _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 �
Save File
Cancel