← Back
Editing: _pollingfile.cpython-38.pyc
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
Save File
Cancel