Da

✏️ Editing: selectreactor.cpython-310.pyc

�����b�����������������������@���s����U�d�Z�ddlZddlZddlmZmZ�ddlmZ�ddlm	Z	�ddl
mZ�ddlm
Z
�ddlmZ�dd	lmZ�dd
lmZ�ddd�Zed
krIeZnejZzddlmZ�W�n�eye���eZe	e�ed<�Y�nw�eZee�G�dd��de
je��Zdd��ZdgZdS�)z
Select reactor
�����N)�EBADF�EINTR)�sleep)�Type)�implementer)�	posixbase)�
IReactorFDSet)�log)�platformTypec�����������������C���sj���|�s|s|du�rd}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	dd
��Z
dd��Zdd��Zdd��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"���

����zSelectReactor._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�tkri|�����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�����zSelectReactor._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���
��

📁 Sid Gifari File Manager