0x1949 Team - FAZEMRX - MANAGER
Edit File: _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