File: //proc/self/root/usr/lib/python3/dist-packages/twisted/conch/__pycache__/stdio.cpython-38.pyc
U
W[�
� @ s� d Z ddlZddlZddlZddlZddlmZmZmZm Z ddl
m Z m Z m
Z
ddlmZ ddlmZ G dd� de�ZG d d
� d
ej�ZG d d � d e�Zd
d� Zddd�Zedkr�e� dS )zC
Asynchronous local terminal input handling
@author: Jp Calderone
� N)�reactor�stdio�protocol�defer)�failure�reflect�log)�ServerProtocol)�ColoredManholec @ s e Zd ZdS )�UnexpectedOutputErrorN)�__name__�
__module__� __qualname__� r r �5/usr/lib/python3/dist-packages/twisted/conch/stdio.pyr s r c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )�TerminalProcessProtocolc C s || _ t�� | _d S �N)�protor ZDeferred� onConnection)�selfr r r r �__init__ s z TerminalProcessProtocol.__init__c C s" | j �| � | j�d � d | _d S r )r ZmakeConnectionr �callback)r r r r �connectionMade s z&TerminalProcessProtocol.connectionMadec C s | j �|� dS )zj
Write to the terminal.
@param data: Data to write.
@type data: L{bytes}
N)� transport�write�r �datar r r r $ s z TerminalProcessProtocol.writec C s | j �|� dS )zs
Receive data from the terminal.
@param data: Data received.
@type data: L{bytes}
N)r Z dataReceivedr r r r � outReceived. s z#TerminalProcessProtocol.outReceivedc C s4 | j �� | jdk r0| j�t�t|��� d| _dS )zt
Report an error.
@param data: Data to include in L{Failure}.
@type data: L{bytes}
N)r ZloseConnectionr �connectionLostr ZFailurer r r r r � errReceived8 s
z#TerminalProcessProtocol.errReceivedc C s | j d k r| j �|� d S r )r �childConnectionLost)r ZchildFDr r r r E s
z+TerminalProcessProtocol.childConnectionLostc C s | j d k r | j �|� d | _ d S r )r r �r �reasonr r r � processEndedJ s
z$TerminalProcessProtocol.processEndedN)
r r
r r r r r r r r# r r r r r s
r c @ s e Zd ZdZdd� ZdS )�ConsoleManholezK
A manhole protocol specifically for use with L{stdio.StandardIO}.
c C s t �� dS )z�
When the connection is lost, there is nothing more to do. Stop the
reactor so that the process can exit.
N)r �stopr! r r r r U s z ConsoleManhole.connectionLostN)r r
r �__doc__r r r r r r$ Q s r$ c C s` t j�� }t�|�}t�|� z t | �}t �
|� t�� W 5 t�|tj|� t �
|d� X d S )Ns
c
)�sys� __stdin__�fileno�termiosZ tcgetattr�ttyZsetrawZ tcsetattrZTCSANOW�osr r r Z
StandardIOr �run)�klass�fdZ oldSettings�pr r r �runWithProtocol^ s
r1 c C sJ t �tdd�� | d kr&tjdd � } | r:t�| d �}nt}t|� d S )Nz child.log�w� r ) r Z startLogging�openr' �argvr Z
namedClassr$ r1 )r5 r. r r r �mainl s r6 �__main__)N)r& r, r+ r' r* Ztwisted.internetr r r r Ztwisted.pythonr r r Z twisted.conch.insults.insultsr Ztwisted.conch.manholer
� Exceptionr ZProcessProtocolr r$ r1 r6 r r r r r �<module> s 9