← Back
Editing: 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
Save File
Cancel