File: //lib/python3/dist-packages/twisted/internet/__pycache__/selectreactor.cpython-38.pyc
U
��W[G � @ s� d Z ddlmZmZ ddlmZ ddlZddlZddlZddl m
Z
m Z ddl m
Z
ddlmZ ddlmZ dd lmZ dd
lmZ dd d �Zed
kr�eZnejZzddlmZ W n ek
r� eZ Y nX eZ e
e�G dd� dej e ��Z dd� Z dgZ dS )z
Select reactor
� )�division�absolute_import)�sleepN)�EINTR�EBADF)� implementer)�
IReactorFDSet)� posixbase)�log)� platformTypec C sj | s2|s2|dkrd}n
t |d�}t|� g g g fS |dksB|dkrFd}t�| |||�\} }}| || g fS )zWin32 select wrapper.Ng{�G�z�?g����MbP?g �?)�minr �select)�r�w�e�timeout� r �@/usr/lib/python3/dist-packages/twisted/internet/selectreactor.py� win32select s
r Zwin32)�_ThreadedWin32EventsMixinc @ sl e Zd ZdZdd� Zdd� Zdd� ZeZdd � Zd
d � Z d d
� Z
dd� Z dd� Z dd� Z
dd� Zdd� ZdS )�
SelectReactora-
A select() based reactor - runs on all POSIX platforms and on Win32.
@ivar _reads: A set containing L{FileDescriptor} instances which will be
checked for read events.
@ivar _writes: A set containing L{FileDescriptor} instances which will be
checked for writability.
c C s t � | _t � | _tj�| � dS )zV
Initialize file descriptor tracking dictionaries and the base class.
N)�set�_reads�_writesr �PosixReactorBase�__init__��selfr r r r B s zSelectReactor.__init__c C s� t �d� t| j�}t| j�}| j�� | j�� | j|f| j|ffD ]v\}}|D ]h}zt�|g|g|gd� W n> tk
r� } z t �d| � | �||d� W 5 d }~X Y qRX |� |� qRqFd S )Nz1Malformed file descriptor found. Preening lists.r zbad descriptor %sF)
r
�msg�listr r �clearr
� Exception�_disconnectSelectable�add)r ZreadersZwritersZselSetZselList�
selectabler r r r �_preenDescriptorsK s
� z SelectReactor._preenDescriptorsc
C sJ z t | j| jg |�\}}}W n� tk
r: | �� Y dS tk
r^ t�� | �� Y dS tj t
j t fk
r� } zf|j d dkr�| js�| js�W Y �FdS � n:|j d t
kr�W Y �*dS |j d tkr�| �� W Y �
dS � W 5 d}~X Y nX | j}tj}|d| jf|d| jffD ]4\}} }
|D ]"} | |
k�r0�q || || | � �q �qdS )z�
Run one iteration of the I/O monitor loop.
This will run all selectables who had input or output readiness
waiting for them.
Nr )r � �doReadZdoWrite)�_selectr r �
ValueErrorr% � TypeErrorr
�errr
�error�socket�IOError�argsr r �_doReadOrWriteZcallWithLogger) r r r r ZignoredZseZ_drdwZ_logrunZ selectables�methodZfdsetr$ r r r �doSelect] sB �
�
zSelectReactor.doSelectc C sL zt ||�� }W n t�� d }t�� Y nX |rH| �|||dk� d S )N� r' )�getattr�sys�exc_infor
r+ r" )r r$ r1 Zwhyr r r r0 � s z SelectReactor._doReadOrWritec C s | j �|� dS )zR
Add a FileDescriptor for notification of data available to read.
N)r r# �r �readerr r r � addReader� s zSelectReactor.addReaderc C s | j �|� dS )zS
Add a FileDescriptor for notification of data available to write.
N)r r# �r �writerr r r � addWriter� s zSelectReactor.addWriterc C s | j �|� dS )zQ
Remove a Selectable for notification of data available to read.
N)r �discardr7 r r r � removeReader� s zSelectReactor.removeReaderc C s | j �|� dS )zR
Remove a Selectable for notification of data available to write.
N)r r= r: r r r � removeWriter� s zSelectReactor.removeWriterc C s | � | j| j�S �N)Z
_removeAllr r r r r r � removeAll� s zSelectReactor.removeAllc C s
t | j�S r@ )r r r r r r �
getReaders� s zSelectReactor.getReadersc C s
t | j�S r@ )r r r r r r �
getWriters� s zSelectReactor.getWritersN)�__name__�
__module__� __qualname__�__doc__r r% r2 Z doIterationr0 r9 r< r> r? rA rB rC r r r r r 6 s
4 r c C s t � } ddlm} || � dS )zIConfigure the twisted mainloop to be run using the select() reactor.
r )�installReactorN)r Ztwisted.internet.mainrH )ZreactorrH r r r �install� s rI )N)!rG Z
__future__r r �timer r5 r
r- �errnor r Zzope.interfacer Ztwisted.internet.interfacesr Ztwisted.internetr Ztwisted.pythonr
Ztwisted.python.runtimer r r( Z"twisted.internet.win32eventreactorr � ImportError�objectZ
_extraBaser r rI �__all__r r r r �<module> s.