Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/protocols/__pycache__/pcp.cpython-39.pyc
Ðазад
a k�h � @ sL d Z ddlmZ ddlmZ eejej�G dd� d��ZG dd� de�ZdS ) z Producer-Consumer Proxy. � )� implementer)� interfacesc @ sz e Zd ZdZdZdZdZdZdZdZ dZ dd� Z dd� Z d d � Z d d � Zd d� Zdd� Zdd� Zdd� Zed�dd�ZdS )�BasicProducerConsumerProxyaa I can act as a man in the middle between any Producer and Consumer. @ivar producer: the Producer I subscribe to. @type producer: L{IProducer<interfaces.IProducer>} @ivar consumer: the Consumer I publish to. @type consumer: L{IConsumer<interfaces.IConsumer>} @ivar paused: As a Producer, am I paused? @type paused: bool NTFc C s& g | _ |d ur"|| _|�| | j� d S �N)�_buffer�consumer�registerProducer� iAmStreaming)�selfr � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/protocols/pcp.py�__init__# s z#BasicProducerConsumerProxy.__init__c C s d| _ | jr| j�� d S �NT)�paused�producer�pauseProducing�r r r r r + s z)BasicProducerConsumerProxy.pauseProducingc C sT d| _ | jr0| j�d�| j�� g | jd d �< n | js<d| _| jd urP| j�� d S )NF� T) r r r �write�joinr �outstandingPullr �resumeProducingr r r r r 0 s z*BasicProducerConsumerProxy.resumeProducingc C s& | j d ur| j �� | jd ur"| `d S r )r � stopProducingr r r r r r = s z(BasicProducerConsumerProxy.stopProducingc C s@ | j s| js | js | j�|� n | jd ur<| j�|� d| _d S �NF)r r r r �appendr r �r �datar r r r E s z BasicProducerConsumerProxy.writec C s | j d ur| j �� | �� d S r )r �finish�unregisterProducerr r r r r N s z!BasicProducerConsumerProxy.finishc C s || _ || _d S r )r �producerIsStreaming�r r Z streamingr r r r S s z+BasicProducerConsumerProxy.registerProducerc C s& | j d ur| ` | `| jr"| j�� d S r )r r r r r r r r r W s z-BasicProducerConsumerProxy.unregisterProducer)�returnc C s" d| j � dt| �d�d| j� d�S )N�<�@�xz around �>)� __class__�idr r r r r �__repr__^ s z#BasicProducerConsumerProxy.__repr__)�__name__� __module__� __qualname__�__doc__r r r r r r �stoppedr r r r r r r r �strr( r r r r r s" r c @ sL e Zd ZdZdZdZdZdd� Zdd� Zdd � Z d d � Z d d � Z dd� Z dS )�ProducerConsumerProxyz�ProducerConsumerProxy with a finite buffer. When my buffer fills up, I have my parent Producer pause until my buffer has room in it again. i Fc C s d| _ d S r )r r r r r r o s z$ProducerConsumerProxy.pauseProducingc C s� d| _ | jrjd�| j�}| �|�}|t|�k rZ||d � }| jrHJ d��|g| jd d �< qng | jd d �< nd}| jr�|r�| js�| jd ur�| j�� | js�| | _ | j d ur�t dd� | jD ��}| j r�|| j k r�d| _ | j �� n| j r�| j �� d S )NFr �.Streaming producer did not write all its data.r c s s | ]}t |�V qd S r ��len��.0�sr r r � <genexpr>� � z8ProducerConsumerProxy.resumeProducing.<locals>.<genexpr>)r r r �_writeSomeDatar2 r � unregisteredr r r r �sum�producerPaused� bufferSizer )r r � bytesSentZunsent� bytesBufferedr r r r t s> ������ z%ProducerConsumerProxy.resumeProducingc C s� | j s| js | js | j�|� nV| jd urv| jr8J d��| �|�}d| _|t|�ksv| jrbJ d��| j�||d � � | jd ur�| j r�t dd� | jD ��}|| j kr�| j� � d| _ d S )Nz9Writing fresh data to consumer before my buffer is empty!Fr0 c s s | ]}t |�V qd S r r1 r3 r r r r6 � r7 z.ProducerConsumerProxy.write.<locals>.<genexpr>T)r r r r r r r8 r2 r r r: r< r r; )r r r= r> r r r r � s( �� �� zProducerConsumerProxy.writec C s$ d| _ t�| ||� |s |�� d S r )r9 r r r r r r r r � s z&ProducerConsumerProxy.registerProducerc C s2 | j d ur| ` | `d| _| jr.| js.| j�� d S r )r r r9 r r r r r r r r � s z(ProducerConsumerProxy.unregisterProducerc C s" | j du rdS | j �|� t|�S )z`Write as much of this data as possible. @returns: The number of bytes written. Nr )r r r2 r r r r r8 � s z$ProducerConsumerProxy._writeSomeDataN) r) r* r+ r, r< r; r9 r r r r r r8 r r r r r/ b s - r/ N) r, Zzope.interfacer Ztwisted.internetr Z IProducerZ IConsumerr r/ r r r r �<module> s S
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка