/usr/lib/python3/dist-packages/twisted/protocols/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/protocols/__pycache__/pcp.cpython-310.pyc (5629B)
o
b @ sL d Z ddlmZ ddlmZ eejejG dd dZG dd deZdS ) 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 ZdefddZdS )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
}
@ivar consumer: the Consumer I publish to.
@type consumer: L{IConsumer}
@ivar paused: As a Producer, am I paused?
@type paused: bool
NTFc C s* g | _ |d ur|| _|| | j d S d S N)_bufferconsumerregisterProducer iAmStreaming)selfr r 7/usr/lib/python3/dist-packages/twisted/protocols/pcp.py__init__# s
z#BasicProducerConsumerProxy.__init__c C s d| _ | jr
| j d S d S NT)pausedproducerpauseProducingr
r r r r + s z)BasicProducerConsumerProxy.pauseProducingc C sX d| _ | jr| jd| j g | jd d < n| js d| _| jd ur*| j d S d S )NF T) r r r writejoinr outstandingPullr resumeProducingr r r r r 0 s
z*BasicProducerConsumerProxy.resumeProducingc C s* | j d ur
| j | jd ur| `d S d S r )r
stopProducingr r r r r r = s
z(BasicProducerConsumerProxy.stopProducingc C sF | j s | js| js| j| d S | jd ur!| j| d| _d S 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 finishunregisterProducerr r r r r N s
z!BasicProducerConsumerProxy.finishc C s || _ || _d S r )r producerIsStreamingr
r streamingr r r r S s
z+BasicProducerConsumerProxy.registerProducerc C s* | j d ur | ` | `| jr| j d S d S r )r r r r r r r r r W s
z-BasicProducerConsumerProxy.unregisterProducerreturnc C s" d| j dt| dd| j dS )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 )ProducerConsumerProxyzProducerConsumerProxy 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| _ | jr5d| j}| |}|t|k r-||d }| jr$J d|g| jd d < n
g | jd d < nd}| jrI|rI| jsI| jd urI| j | jsP| | _ | j
d ur{t dd | jD }| j rq|| j
k rqd| _ | j
d S | j r}| j
d S d S d S )NFr .Streaming producer did not write all its data.r c s | ]}t |V qd S r len.0sr r r z8ProducerConsumerProxy.resumeProducing..)r r r _writeSomeDatar4 r unregisteredr r r r sumproducerPaused
bufferSizer )r
r bytesSentunsent
bytesBufferedr r r r t s@
z%ProducerConsumerProxy.resumeProducingc C s | j s | js| js| j| n+| jd ur;| jr J d| |}d| _|t|ks;| jr1J d| j||d | jd ur\| j r^t
dd | jD }|| j kr`| j d| _
d S d S d S d S )Nz9Writing fresh data to consumer before my buffer is empty!Fr1 c s r2 r r3 r5 r r r r8 r9 z.ProducerConsumerProxy.write..T)r r r r r r r: r4 r r r< r> r r= )r
r r? rA r r r r s,
zProducerConsumerProxy.writec C s( d| _ t| || |s| d S d S r )r; r r r r r r r r s
z&ProducerConsumerProxy.registerProducerc C s: | j d ur | ` | `d| _| jr| js| j d S d S d S r )r r r; 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 r4 r r r r r: s
z$ProducerConsumerProxy._writeSomeDataN)
r* r+ r, r- r> r= r; r r r r r r: r r r r r0 b s - r0 N) r- zope.interfacer twisted.internetr IProducer IConsumerr r0 r r r r s S