Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/internet/__pycache__/_posixstdio.cpython-39.pyc
Ðазад
a k�h� � @ st d Z ddlmZ ddlmZmZmZ ddlmZm Z eej �G dd� d��Z eej ej ejej�G dd� d��Zd S ) z�Standard input/out/err support. Future Plans:: support for stderr, perhaps Rewrite to use the reactor instead of an ad-hoc mechanism for connecting protocols to transport. Maintainer: James Y Knight � )� implementer)�error� interfaces�process)�failure�logc @ s e Zd ZdS )� PipeAddressN)�__name__� __module__� __qualname__� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/internet/_posixstdio.pyr s r c @ s� e Zd ZdZdZdZdZd/dd�Zdd� Zd d � Z d d � Z d d� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� ZdS )0� StandardIONFr � c C sX |d u rddl m} || _t�|| d|�| _t�|| d|�| _| j�� | j� | � d S )Nr )�reactor�write�read) �twisted.internetr �protocolr Z ProcessWriter�_writerZ ProcessReader�_reader� startReadingZmakeConnection)�self�proto�stdin�stdoutr r r r �__init__& s zStandardIO.__init__c C s | j d ur| j �� d S �N)r �loseConnection�r r r r �loseWriteConnection3 s z StandardIO.loseWriteConnectionc C s | j d ur| j �|� d S r )r r �r �datar r r r 7 s zStandardIO.writec C s | j d ur| j �|� d S r )r � writeSequencer! r r r r# ; s zStandardIO.writeSequencec C s2 d| _ | jd ur| j�� | jd ur.| j�� d S �NT)� disconnectingr r r � stopReadingr r r r r ? s zStandardIO.loseConnectionc C s t � S r �r r r r r �getPeerH s zStandardIO.getPeerc C s t � S r r' r r r r �getHostK s zStandardIO.getHostc C s | j �|� d S r )r Z dataReceived)r �fdr" r r r �childDataReceivedO s z StandardIO.childDataReceivedc C sF | j r d S |jjtjkr8|dkr,| �|� qB| �|� n | �|� d S )Nr )� disconnected�value� __class__r ZConnectionDone�_readConnectionLost�_writeConnectionLost�connectionLost)r r* �reasonr r r �childConnectionLostR s z StandardIO.childConnectionLostc C s� d| _ | j}| j}| j}d | _| _d | _|d urB|j sB|�|� |d urZ|j sZ|�|� z|�|� W n ty� t�� Y n0 d S r$ )r, r r r r1 � BaseExceptionr �err)r r2 r r r r r r r1 _ s zStandardIO.connectionLostc C sf d | _ | jr| �|� d S t�| jd �}|rbz |�� W n( ty` t� � | �t � � � Y n0 d S r ) r r% r1 r �IHalfCloseableProtocolr �writeConnectionLostr4 r r5 r �Failure�r r2 �pr r r r0 t s z StandardIO._writeConnectionLostc C s^ d | _ t�| jd �}|rPz |�� W qZ tyL t�� | �t � � � Y qZ0 n | �|� d S r ) r r r6 r �readConnectionLostr4 r r5 r1 r r8 r9 r r r r/ � s z StandardIO._readConnectionLostc C s& | j d u r|�� n| j �||� d S r )r � stopProducing�registerProducer)r ZproducerZ streamingr r r r= � s zStandardIO.registerProducerc C s | j d ur| j �� d S r )r �unregisterProducerr r r r r> � s z StandardIO.unregisterProducerc C s | � � d S r )r r r r r r< � s zStandardIO.stopProducingc C s | j d ur| j �� d S r )r �pauseProducingr r r r r? � s zStandardIO.pauseProducingc C s | j d ur| j �� d S r )r �resumeProducingr r r r r@ � s zStandardIO.resumeProducingc C s | � � dS )z3Compatibility only, don't use. Call pauseProducing.N)r? r r r r r& � s zStandardIO.stopReadingc C s | � � dS )z4Compatibility only, don't use. Call resumeProducing.N)r@ r r r r r � s zStandardIO.startReadingc C s t � �d S r ��NotImplementedError�r r2 r r r r; � s z StandardIO.readConnectionLostc C s t � �d S r rA rC r r r r7 � s z StandardIO.writeConnectionLost)r r N) r r r r r r, r% r r r r# r r( r) r+ r3 r1 r0 r/ r= r> r< r? r@ r& r r; r7 r r r r r s2 r N)�__doc__Zzope.interfacer r r r r Ztwisted.pythonr r ZIAddressr Z ITransportZ IProducerZ IConsumerZIHalfCloseableDescriptorr r r r r �<module> s �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка