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