| Server IP : 138.197.176.125 / Your IP : 216.73.217.55 Web Server : Apache/2.4.41 (Ubuntu) System : Linux SuiteCRM-8 5.4.0-216-generic #236-Ubuntu SMP Fri Apr 11 19:53:21 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.3.19 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/internet/__pycache__/ |
Upload File : |
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