Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/internet/__pycache__/selectreactor.cpython-39.pyc
Ðазад
a k�h� � @ s� U d Z ddlZddlZddlmZmZ ddlmZ ddlm Z ddl m Z ddl m Z ddlmZ dd lmZ dd lmZ dd d �Zed kr�eZnejZzddlmZ W n" ey� eZe e ed< Y n0 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 | s2|s2|du rd}n t |d�}t|� g g g fS |du sB|dkrFd}t�| |||�\} }}| || g fS )zWin32 select wrapper.Ng{�G�z�?g����MbP?g �?)�minr �select)�r�w�e�timeout� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-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 ]x\}}|D ]j}zt�|g|g|gd� W n@ ty� } z(t �d| � | �||d� W Y d }~qRd }~0 0 |� |� 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 �_preenDescriptorsL s $z SelectReactor._preenDescriptorsc C sJ z t | j| jg |�\}}}W n� ty8 | �� Y dS tyZ t�� | �� Y dS ty� } zz|j d dv r�| js�| js�W Y d}~dS � nB|j d t kr�W Y d}~dS |j d t kr�| �� W Y d}~dS � W Y d}~n d}~0 0 | j }tj }|d| jf|d| jffD ]4\}} } |D ]"} | | v�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 �err�OSError�argsr r �_doReadOrWriteZcallWithLogger) r r r r Zignored�seZ_drdwZ_logrunZ selectables�methodZfdsetr% r r r �doSelect\ s: � zSelectReactor.doSelectc C sR zt ||�� }W n& ty6 t�� d }t�� Y n0 |rN| �|||dk� d S )N� r( )�getattr� BaseException�sys�exc_infor r, r# )r r% r1 �whyr r r r/ � 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 �discardr9 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 rB )r r r r r r � getReaders� s zSelectReactor.getReadersc C s t | j�S rB )r r r r r r � getWriters� s zSelectReactor.getWritersN)�__name__� __module__� __qualname__�__doc__r r& r2 Z doIterationr/ r; r> r@ rA rC rD rE 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 Ztwisted.internet.mainrJ )ZreactorrJ r r r �install� s rK )N) rI r r6 �errnor r �timer �typingr Zzope.interfacer Ztwisted.internetr Ztwisted.internet.interfacesr Ztwisted.pythonr Ztwisted.python.runtimer r r) Z"twisted.internet.win32eventreactorr � ImportError�objectr �__annotations__r r rK �__all__r r r r �<module> s0
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка