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