File: //usr/lib/python3/dist-packages/twisted/internet/__pycache__/_win32stdio.cpython-310.pyc
o
�bD � @ s� d Z ddlZddlZddlmZ ddlZddlmZmZ ddl m
Z
m Z m Z m
Z
mZ ddlmZ ee
�G dd� d��Zeee e
�G d d
� d
ej��ZdS ) zM
Windows-specific implementation of the L{twisted.internet.stdio} interface.
� N)� implementer)� _pollingfile�main)�IAddress� IConsumer�IHalfCloseableProtocol�
IPushProducer�
ITransport)�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� |du r
ddl m} tddd�D ] }t�|tj� qtj� | |� || _
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�msvcrt�setmode�os�O_BINARYr �
_PollingTimer�__init__�proto�win32api� GetStdHandle�STD_INPUT_HANDLE�STD_OUTPUT_HANDLE�_PollableReadPipe� dataReceived�readConnectionLost�stdin�_PollableWritePipe�writeConnectionLost�stdout�_addPollableResource�makeConnection)�selfr r �stdfd�hstdin�hstdoutr r r r % s
� zStandardIO.__init__c C � | j �|� d S �N)r r# �r+ �datar r r r# B � zStandardIO.dataReceivedc C �" t �| j�r | j�� | �� d S r0 )r �
providedByr r$ �
checkConnLost�r+ r r r r$ E �
z StandardIO.readConnectionLostc C r4 r0 )r r5 r r' r6 r7 r r r r' J r8 z StandardIO.writeConnectionLostr c C s> | j d7 _ | j dkr d| _d| _| j�ttj�� d S d S )Nr r T)� connsLost�
disconnecting� disconnectedr �connectionLostr
r �CONNECTION_DONEr7 r r r r6 Q s
�zStandardIO.checkConnLostc C r/ r0 )r( �writer1 r r r r> Z r3 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( r7 r r r �loseConnection` s
zStandardIO.loseConnectionc C � t � S r0 �r r7 r r r �getPeere � zStandardIO.getPeerc C rE r0 rF r7 r r r �getHosth rH zStandardIO.getHostc C s | j �||�S r0 )r( �registerProducer)r+ �producer� streamingr r r rJ m � zStandardIO.registerProducerc C s
| j �� S r0 )r( �unregisterProducerr7 r r r rN p s
z StandardIO.unregisterProducerc C � | j �� d S r0 )r% �
stopProducingr7 r r r rP w rM zStandardIO.stopProducingc C rO r0 )r% �pauseProducingr7 r r r rQ | rM zStandardIO.pauseProducingc C rO r0 )r% �resumeProducingr7 r r r rR rM zStandardIO.resumeProducingr0 )r r
r r: r; r r# r$ r' r9 r6 r> rB rD rG rI rJ rN rP rQ rR r r r r r s&
r )�__doc__r r �zope.interfacer r r r r �twisted.internet.interfacesr r r r r �twisted.python.failurer
r r r r r r r �<module> s