File: //usr/lib/python3/dist-packages/twisted/internet/__pycache__/selectreactor.cpython-310.pyc
o
�b� � @ s� U d Z ddlZddlZddlmZmZ ddlmZ ddlm Z ddl
m Z ddl m
Z
ddlmZ dd lmZ dd
lmZ dd d �Zed
krIeZnejZzddlmZ W n eye eZe e ed< Y nw eZe e�G dd� de
j e��Z dd� Z dgZ dS )z
Select reactor
� N)�EBADF�EINTR)�sleep)�Type)� implementer)� posixbase)�
IReactorFDSet)�log)� platformTypec C sj | s|s|du r d}nt |d�}t|� g g g fS |du s!|dkr#d}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 �win32)�_ThreadedWin32EventsMixin�
_extraBasec @ 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 D s zSelectReactor.__init__c C s� t �d� t| j�}t| j�}| j�� | j�� | j|f| j|ffD ]<\}}|D ]5}z
t�|g|g|gd� W n tyX } zt �d| � | �||d� W Y d }~q)d }~ww |� |� q)q#d S )Nz1Malformed file descriptor found. Preening lists.r zbad descriptor %sF)
r �msg�listr r �clearr � Exception�_disconnectSelectable�add)r �readers�writers�selSet�selList�
selectabler r r r �_preenDescriptorsL s"
�� ��z SelectReactor._preenDescriptorsc
C s4 zt | j| jg |�\}}}W n` ty | �� Y dS ty- t�� | �� Y dS tyn } z6|j d dv rI| jsH| jsHW Y d}~dS � |j d t
krWW Y d}~dS |j d t kri| �� W Y d}~dS � d}~ww | j }tj
}|d| jf|d| jffD ]\}} }
|D ]} | |
vr�q�|| || | � q�q�dS )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 � �doRead�doWrite)�_selectr r �
ValueErrorr* � TypeErrorr �err�OSError�argsr r �_doReadOrWrite�callWithLogger) r r r
r �ignored�se�_drdw�_logrun� selectables�method�fdsetr) r r r �doSelect\ sB ��
���zSelectReactor.doSelectc C sV zt ||�� }W n ty t�� d }t�� Y nw |r)| �|||dk� d S d S )N� r, )�getattr�
BaseException�sys�exc_infor r1 r# )r r) r; �whyr r r r4 � s ��z SelectReactor._doReadOrWritec C � | j �|� dS )zR
Add a FileDescriptor for notification of data available to read.
N)r r$ �r �readerr r r � addReader� � zSelectReactor.addReaderc C rD )zS
Add a FileDescriptor for notification of data available to write.
N)r r$ �r �writerr r r � addWriter� rH zSelectReactor.addWriterc C rD )zQ
Remove a Selectable for notification of data available to read.
N)r �discardrE r r r � removeReader� rH zSelectReactor.removeReaderc C rD )zR
Remove a Selectable for notification of data available to write.
N)r rL rI r r r � removeWriter� rH zSelectReactor.removeWriterc C s | � | j| j�S �N)�
_removeAllr r r r r r � removeAll� s zSelectReactor.removeAllc C �
t | j�S rO )r r r r r r �
getReaders� �
zSelectReactor.getReadersc C rR rO )r r r r r r �
getWriters� rT zSelectReactor.getWritersN)�__name__�
__module__� __qualname__�__doc__r r* r= � doIterationr4 rG rK rM rN rQ rS rU r r r r r 8 s
4 r c C s t � } ddlm} || � dS )zDConfigure the twisted mainloop to be run using the select() reactor.r )�installReactorN)r �twisted.internet.mainr[ )�reactorr[ r r r �install� s r^ rO ) rY r rA �errnor r �timer �typingr �zope.interfacer �twisted.internetr �twisted.internet.interfacesr �twisted.pythonr �twisted.python.runtimer
r r. �"twisted.internet.win32eventreactorr � ImportError�objectr �__annotations__r r r^ �__all__r r r r �<module> s4
�