File: //lib/python3/dist-packages/twisted/internet/__pycache__/_win32stdio.cpython-38.pyc
U
W[� � @ s� d Z ddlmZmZ ddlZddlZddlZddlmZ ddl m
Z
m Z m Z m
Z
mZ ddlmZmZ ddlmZ ee�G dd � d e��Zee e e
�G d
d � d ej��ZdS ) zM
Windows-specific implementation of the L{twisted.internet.stdio} interface.
� )�absolute_import�divisionN)� implementer)�IHalfCloseableProtocol�
ITransport� IConsumer�
IPushProducer�IAddress)� _pollingfile�main)�Failurec @ s e Zd ZdS )�Win32PipeAddressN)�__name__�
__module__� __qualname__� r r �>/usr/lib/python3/dist-packages/twisted/internet/_win32stdio.pyr
s r
c @ s� e Zd ZdZdZd"dd�Zdd� Zdd� Zd d
� Zd Z d d
� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� ZdS )#�
StandardIOFNc C s� |dkrddl m} tddd�D ]}t�|tj� q tj� | |� || _
t � t j
�}t � t j�}t�|| j| j�| _t�|| j�| _| �| j� | �| j� | j
�| � dS )z�
Start talking to standard IO with the given protocol.
Also, put it stdin/stdout/stderr into binary mode.
Nr )�reactor� � )�twisted.internetr �range�msvcrtZsetmode�osZO_BINARYr
�
_PollingTimer�__init__�proto�win32apiZ GetStdHandleZSTD_INPUT_HANDLEZSTD_OUTPUT_HANDLEZ_PollableReadPipe� dataReceived�readConnectionLost�stdinZ_PollableWritePipe�writeConnectionLost�stdoutZ_addPollableResourceZmakeConnection)�selfr r ZstdfdZhstdinZhstdoutr r r r s( � � zStandardIO.__init__c C s | j �|� d S �N)r r �r$ �datar r r r > s zStandardIO.dataReceivedc C s" t �| j�r| j�� | �� d S r% )r �
providedByr r �
checkConnLost�r$ r r r r B s
z StandardIO.readConnectionLostc C s" t �| j�r| j�� | �� d S r% )r r( r r" r) r* r r r r" H s
z StandardIO.writeConnectionLostr c C s: | j d7 _ | j dkr6d| _d| _| j�ttj�� d S )Nr r T)� connsLost�
disconnecting� disconnectedr ZconnectionLostr r ZCONNECTION_DONEr* r r r r) P s
zStandardIO.checkConnLostc C s | j �|� d S r% )r# �writer& r r r r. Y s zStandardIO.writec C s | j �d�|�� d S )N� )r# r. �join)r$ �seqr r r �
writeSequence] s zStandardIO.writeSequencec C s d| _ | j�� | j�� d S )NT)r, r! �closer# r* r r r �loseConnectiona s
zStandardIO.loseConnectionc C s t � S r% �r
r* r r r �getPeerg s zStandardIO.getPeerc C s t � S r% r5 r* r r r �getHostk s zStandardIO.getHostc C s | j �||�S r% )r# �registerProducer)r$ ZproducerZ streamingr r r r8 p s zStandardIO.registerProducerc C s
| j �� S r% )r# �unregisterProducerr* r r r r9 t s z StandardIO.unregisterProducerc C s | j �� d S r% )r! �
stopProducingr* r r r r: { s zStandardIO.stopProducingc C s | j �� d S r% )r! �pauseProducingr* r r r r; � s zStandardIO.pauseProducingc C s | j �� d S r% )r! �resumeProducingr* r r r r< � s zStandardIO.resumeProducing)N)r r r r, r- r r r r" r+ r) r. r2 r4 r6 r7 r8 r9 r: r; r< r r r r r s$
r )�__doc__Z
__future__r r r r r Zzope.interfacer Ztwisted.internet.interfacesr r r r r r r
r Ztwisted.python.failurer �objectr
r r r r r r �<module> s