| 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 ddlmZ ddlmZmZ ddl m
Z
dZ dZ G dd � d �Z
G d
d � d �Zdd lZdd lZdd lZdd lZee�G d
d� de
��ZdZee�G dd� de
��Zd S )z�
Implements a simple polling interface for file descriptors that don't work with
select() - this is pretty much only useful on Windows.
� )�absolute_import�division)� implementer)� IConsumer�
IPushProducer)�unicodeg��&� .>g�������?c @ s e Zd ZdZdd� Zdd� ZdS )�_PollableResourceTc C s
d| _ d S �NT��active��self� r �?/usr/lib/python3/dist-packages/twisted/internet/_pollingfile.py�activate s z_PollableResource.activatec C s
d| _ d S �NFr
r r r r �
deactivate s z _PollableResource.deactivateN)�__name__�
__module__� __qualname__r r r r r r r r s r c @ sT e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dS )�
_PollingTimerc C s" || _ g | _d | _t| _d| _d S r )�reactor�
_resources�
_pollTimer� MAX_TIMEOUT�_currentTimeout�_paused)r
r r r r �__init__% s
z_PollingTimer.__init__c C s | j �|� | �� d S �N)r �append�_checkPollingState)r
�resr r r �_addPollableResource, s z"_PollingTimer._addPollableResourcec C s* | j D ]}|jr| �� q&q| �� d S r )r r �
_startPolling� _stopPolling)r
�resourcer r r r 0 s
z _PollingTimer._checkPollingStatec C s | j d kr| �� | _ d S r )r � _rescheduler r r r r# 8 s
z_PollingTimer._startPollingc C s | j d k r| j �� d | _ d S r )r Zcancelr r r r r$ < s
z_PollingTimer._stopPollingc C s
d| _ d S r )r r r r r �_pauseA s z_PollingTimer._pausec C s d| _ | �� d S r )r r r r r r �_unpauseD s z_PollingTimer._unpausec C s | j s| j�| j| j�S d S r )r r Z callLaterr �
_pollEventr r r r r& H s z_PollingTimer._reschedulec C s� d}g }| j D ]&}|jr||�� 7 }|jr|�|� q| j}|r\| j|d }|tk rrt}n| jd }|tkrrt}|| _|r�| �� | _d S )Ng g �?g @) r r � checkWorkr r � MIN_TIMEOUTr r& r )r
Z workUnitsZ anyActiver% Z
newTimeoutr r r r) L s$
z_PollingTimer._pollEventN) r r r r r" r r# r$ r' r( r& r) r r r r r " s r Nc @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )�_PollableReadPipec C s || _ || _|| _d S r )�pipe�receivedCallback� lostCallback)r
r- r. r/ r r r r o s z_PollableReadPipe.__init__c C s� d}g }z>t �| jd�\}}}|s&W qht�| j|d �\}}|�|� W q tjk
rd d}Y qhY qX qd�|�}|r�| � |� |r�| �
� t |�S )Nr � � ) � win32pipeZ
PeekNamedPiper- � win32fileZReadFiler �win32api�error�joinr. �cleanup�len) r
ZfinishedZ fullDataRead�bufferZ bytesToRead�resultZhr�dataZdataBufr r r r* u s"
z_PollableReadPipe.checkWorkc C s | � � | �� d S r )r r/ r r r r r7 � s z_PollableReadPipe.cleanupc C s, zt �| j� W n tjk
r& Y nX d S r )r4 � CloseHandler- �
pywintypesr5 r r r r �close� s z_PollableReadPipe.closec C s | � � d S r )r> r r r r �
stopProducing� s z _PollableReadPipe.stopProducingc C s | � � d S r )r r r r r �pauseProducing� s z _PollableReadPipe.pauseProducingc C s | � � d S r )r r r r r �resumeProducing� s z!_PollableReadPipe.resumeProducingN)
r r r r r* r7 r> r? r@ rA r r r r r, l s r, i c @ s\ e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dS )�_PollableWritePipec C s\ d| _ d | _d| _d| _g | _|| _|| _zt�|tj d d � W n t
j k
rV Y nX d S )NFr ) �
disconnecting�producer�producerPaused�streamingProducer�outQueue� writePiper/ r2 ZSetNamedPipeHandleStateZ PIPE_NOWAITr= r5 )r
rH r/ r r r r � s �z_PollableWritePipe.__init__c C s
d| _ d S r )rC r r r r r> � s z_PollableWritePipe.closec C s | j d k rd| _| j �� d S r )rD rE r@ r r r r �
bufferFull� s
z _PollableWritePipe.bufferFullc C s0 | j d k r,| jr| jr,d| j _| j �� dS dS )NFT)rD rF rE rA r r r r � bufferEmpty� s �
z _PollableWritePipe.bufferEmptyc C sH | j dk r td|| j f ��| js,|�� n|| _ || _|sD|�� dS )aw Register to receive data from a producer.
This sets this selectable to be a consumer for a producer. When this
selectable runs out of data on a write() call, it will ask the producer
to resumeProducing(). A producer should implement the IProducer
interface.
FileDescriptor provides some infrastructure for producer methods.
NzHCannot register producer %s, because producer %s was never unregistered.)rD � RuntimeErrorr r? rF rA )r
rD Z streamingr r r �registerProducer� s
��
z#_PollableWritePipe.registerProducerc C s
d| _ dS )zDStop consuming data from a producer, without disconnecting.
N)rD r r r r �unregisterProducer� s z%_PollableWritePipe.unregisterProducerc C s< | � � zt�| j� W n tjk
r. Y nX | �� d S r )r r4 r< rH r= r5 r/ r r r r �writeConnectionLost� s z&_PollableWritePipe.writeConnectionLostc C s& t tt|�krtd��| j�|� dS )z�
Append a C{list} or C{tuple} of bytes to the output buffer.
@param seq: C{list} or C{tuple} of C{str} instances to be appended to
the output buffer.
@raise TypeError: If C{seq} contains C{unicode}.
�%Unicode not allowed in output buffer.N)r �map�type� TypeErrorrG �extend)r
�seqr r r �
writeSequence� s z _PollableWritePipe.writeSequencec C sH t |t�rtd��| jr dS | j�|� ttt| j��t krD| �
� dS )z�
Append some bytes to the output buffer.
@param data: C{str} to be appended to the output buffer.
@type data: C{str}.
@raise TypeError: If C{data} is C{unicode} instead of C{str}.
rO N) �
isinstancer rR rC rG r �sumrP r8 �FULL_BUFFER_SIZErI )r
r; r r r �write� s
z_PollableWritePipe.writec C s� d}| j sT| jr | �� dS zt�| jdd � W n" tjk
rR | �� | Y S X | j r�| j �d�}d}zt�| j|d �\}}W n" t jk
r� | �� Y q�Y qTX ||7 }t
|�|krT| j � d||d � � q�qT| � � }|s�| jr�| �� |S )Nr r1 )
rG rC rN r3 Z WriteFilerH r= r5 �popr4 r8 �insertrJ )r
ZnumBytesWrittenr; ZerrCodeZ
nBytesWrittenZresumedr r r r* s:
�
z _PollableWritePipe.checkWorkN)
r r r r r> rI rJ rL rM rN rU rY r* r r r r rB � s
rB )�__doc__Z
__future__r r Zzope.interfacer Ztwisted.internet.interfacesr r Ztwisted.python.compatr r+ r r r r2 r3 r4 r= r, rX rB r r r r �<module> s" E4