File manager - Edit - /usr/lib/python3/dist-packages/twisted/internet/__pycache__/selectreactor.cpython-310.pyc
Back
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 �
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings