File: //proc/self/root/lib/python3/dist-packages/twisted/internet/__pycache__/pollreactor.cpython-38.pyc
U
��W[� � @ s� d Z ddlmZmZ ddlZddlmZmZ ddlm Z m
Z
m Z m Z m
Z
ddlmZ ddlmZ ddlmZ dd lmZ ee�G d
d � d ejej��Zd d
� Zd d
gZdS )z�
A poll() based implementation of the twisted main loop.
To install the event loop (and you should do this before any connections,
listeners or connectors are added)::
from twisted.internet import pollreactor
pollreactor.install()
� )�division�absolute_importN)�error�poll)�POLLIN�POLLOUT�POLLHUP�POLLERR�POLLNVAL)� implementer)�log)� posixbase)�
IReactorFDSetc @ s� e Zd ZdZeeB eB ZeZ e
Z dd� Z dd� Z
dd� Zdd � Zd
d � Zd d
� Zdd� Zdd� Zdd� ZeZdd� Zdd� ZdS )� PollReactora^
A reactor that uses poll(2).
@ivar _poller: A L{select.poll} which will be used to check for I/O
readiness.
@ivar _selectables: A dictionary mapping integer file descriptors to
instances of L{FileDescriptor} which have been registered with the
reactor. All L{FileDescriptor}s which are currently receiving read or
write readiness notifications will be present as values in this
dictionary.
@ivar _reads: A dictionary mapping integer file descriptors to arbitrary
values (this is essentially a set). Keys in this dictionary will be
registered with C{_poller} for read readiness notifications which will
be dispatched to the corresponding L{FileDescriptor} instances in
C{_selectables}.
@ivar _writes: A dictionary mapping integer file descriptors to arbitrary
values (this is essentially a set). Keys in this dictionary will be
registered with C{_poller} for write readiness notifications which will
be dispatched to the corresponding L{FileDescriptor} instances in
C{_selectables}.
c C s* t � | _i | _i | _i | _tj�| � dS )zo
Initialize polling object, file descriptor tracking dictionaries, and
the base class.
N)r �_poller� _selectables�_reads�_writesr
�PosixReactorBase�__init__��self� r �>/usr/lib/python3/dist-packages/twisted/internet/pollreactor.pyr = s
zPollReactor.__init__c C s| z| j �|� W n tk
r$ Y nX d}|| jkr<|tB }|| jkrN|tB }|dkrf| j �||� n|| jkrx| j|= dS )z*Register/unregister an fd with the poller.r N) r Z
unregister�KeyErrorr r r r �registerr )r �fd�maskr r r �_updateRegistrationI s
z PollReactor._updateRegistrationc C sd z|� � }|| W n2 | j�� D ]\}}||kr& qBq&Y d S Y nX ||kr`||= | �|� d S )N)�filenor �itemsr )r �
selectableZmdictr Zfdesr r r � _dictRemove[ s zPollReactor._dictRemovec C s4 |� � }|| jkr0|| j|< d| j|< | �|� dS )zIAdd a FileDescriptor for notification of data available to read.
� N)r r r r )r �readerr r r r � addReaderp s
zPollReactor.addReaderc C s4 |� � }|| jkr0|| j|< d| j|< | �|� dS )zJAdd a FileDescriptor for notification of data available to write.
r# N)r r r r )r �writerr r r r � addWritery s
zPollReactor.addWriterc C s | � || j�S )zHRemove a Selectable for notification of data available to read.
)r" r )r r$ r r r � removeReader� s zPollReactor.removeReaderc C s | � || j�S )zIRemove a Selectable for notification of data available to write.
)r" r )r r& r r r � removeWriter� s zPollReactor.removeWriterc s, � � � fdd�� jD �� fdd�� jD ��S )zD
Remove all selectables, and return a list of them.
c s g | ]}� j | �qS r �r ��.0r r r r �
<listcomp>� s z)PollReactor.removeAll.<locals>.<listcomp>c s g | ]}� j | �qS r r* r+ r r r r- � s )Z
_removeAllr r r r r r � removeAll� s �zPollReactor.removeAllc
C s� |dk rt |d �}z| j�|�}W n> tk
rb } z |jd tjkrPW Y �
dS � W 5 d}~X Y nX | j}|D ]B\}}z| j| }W n t k
r� Y qnY nX t
� |||||� qndS )z Poll the poller for new events.Ni� r ) �intr r � SelectError�args�errnoZEINTRZ_doReadOrWriter r r ZcallWithLogger)r Ztimeout�l�eZ_drdwr Zeventr! r r r �doPoll� s
zPollReactor.doPollc s � fdd�� j D �S )Nc s g | ]}� j | �qS r r* r+ r r r r- � s z*PollReactor.getReaders.<locals>.<listcomp>)r r r r r �
getReaders� s zPollReactor.getReadersc s � fdd�� j D �S )Nc s g | ]}� j | �qS r r* r+ r r r r- � s z*PollReactor.getWriters.<locals>.<listcomp>)r r r r r �
getWriters� s zPollReactor.getWritersN)�__name__�
__module__� __qualname__�__doc__r r r
Z_POLL_DISCONNECTEDr Z_POLL_INr Z _POLL_OUTr r r" r% r' r( r) r. r5 Z doIterationr6 r7 r r r r r s r c C s t � } ddlm} || � dS )zInstall the poll() reactor.r )�installReactorN)r Ztwisted.internet.mainr< )�pr< r r r �install� s r> )r; Z
__future__r r r2 Zselectr r0 r r r r r r
Zzope.interfacer Ztwisted.pythonr Ztwisted.internetr
Ztwisted.internet.interfacesr r Z_PollLikeMixinr r> �__all__r r r r �<module> s