Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/internet/__pycache__/pollreactor.cpython-39.pyc
Ðазад
a k�hV � @ s� d Z ddlZddlmZmZmZmZmZmZ m Z ddl m Z ddl mZ ddlmZ ddlmZ e e�G dd � d ejej��Zd d � Zd d gZdS ) z� A poll() based implementation of the twisted main loop. To install the event loop (and you should do this before any connections, listeners or connectors are added):: from twisted.internet import pollreactor pollreactor.install() � N)�POLLERR�POLLHUP�POLLIN�POLLNVAL�POLLOUT�error�poll)� implementer)� posixbase)� IReactorFDSet)�logc @ s� e Zd ZdZeeB eB ZeZ e Z dd� Z dd� Z dd� Zdd � Zd d � Zd d � Zdd� Zdd� Zdd� ZeZdd� Zdd� ZdS )� PollReactora^ A reactor that uses poll(2). @ivar _poller: A L{select.poll} which will be used to check for I/O readiness. @ivar _selectables: A dictionary mapping integer file descriptors to instances of L{FileDescriptor} which have been registered with the reactor. All L{FileDescriptor}s which are currently receiving read or write readiness notifications will be present as values in this dictionary. @ivar _reads: A dictionary mapping integer file descriptors to arbitrary values (this is essentially a set). Keys in this dictionary will be registered with C{_poller} for read readiness notifications which will be dispatched to the corresponding L{FileDescriptor} instances in C{_selectables}. @ivar _writes: A dictionary mapping integer file descriptors to arbitrary values (this is essentially a set). Keys in this dictionary will be registered with C{_poller} for write readiness notifications which will be dispatched to the corresponding L{FileDescriptor} instances in C{_selectables}. c C s* t � | _i | _i | _i | _tj�| � dS )zo Initialize polling object, file descriptor tracking dictionaries, and the base class. N)r �_poller� _selectables�_reads�_writesr �PosixReactorBase�__init__��self� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/internet/pollreactor.pyr C s zPollReactor.__init__c C sz z| j �|� W n ty" Y n0 d}|| jv r:|tB }|| jv rL|tB }|dkrd| j �||� n|| jv rv| j|= dS )z*Register/unregister an fd with the poller.r N) r � unregister�KeyErrorr r r r �registerr )r �fd�maskr r r �_updateRegistrationN s z PollReactor._updateRegistrationc C sj z|� � }|| W n8 tyL | j�� D ]\}}||u r, qHq,Y d S Y n0 ||v rf||= | �|� d S )N)�fileno� BaseExceptionr �itemsr )r � selectableZmdictr Zfdesr r r � _dictRemove` s zPollReactor._dictRemovec C s4 |� � }|| jvr0|| j|< d| j|< | �|� dS )z@Add a FileDescriptor for notification of data available to read.� N)r r r r )r �readerr r r r � addReaderu s zPollReactor.addReaderc C s4 |� � }|| jvr0|| j|< d| j|< | �|� dS )zAAdd a FileDescriptor for notification of data available to write.r# N)r r r r )r �writerr r r r � addWriter} s zPollReactor.addWriterc C s | � || j�S )z?Remove a Selectable for notification of data available to read.)r" r )r r$ r r r � removeReader� s zPollReactor.removeReaderc C s | � || j�S )z@Remove a Selectable for notification of data available to write.)r" r )r r& r r r � removeWriter� s zPollReactor.removeWriterc s, � � � fdd�� jD �� fdd�� jD ��S )zD Remove all selectables, and return a list of them. c s g | ]}� j | �qS r �r ��.0r r r r � <listcomp>� � z)PollReactor.removeAll.<locals>.<listcomp>c s g | ]}� j | �qS r r* r+ r r r r- � r. )Z _removeAllr r r r r r � removeAll� s �zPollReactor.removeAllc C s� |durt |d �}z| j�|�}W nD tyh } z,|jd tjkrRW Y d}~dS � W Y d}~n d}~0 0 | j}|D ]@\}}z| j| }W n t y� Y qtY n0 t � |||||� qtdS )z Poll the poller for new events.Ni� r ) �intr r � SelectError�args�errnoZEINTRZ_doReadOrWriter r r ZcallWithLogger)r �timeout�l�eZ_drdwr �eventr! r r r �doPoll� s zPollReactor.doPollc s � fdd�� j D �S )Nc s g | ]}� j | �qS r r* r+ r r r r- � r. z*PollReactor.getReaders.<locals>.<listcomp>)r r r r r � getReaders� s zPollReactor.getReadersc s � fdd�� j D �S )Nc s g | ]}� j | �qS r r* r+ r r r r- � r. z*PollReactor.getWriters.<locals>.<listcomp>)r r r r r � getWriters� s zPollReactor.getWritersN)�__name__� __module__� __qualname__�__doc__r r r Z_POLL_DISCONNECTEDr Z_POLL_INr Z _POLL_OUTr r r" r% r' r( r) r/ r8 Z doIterationr9 r: r r r r r $ s r c C s t � } ddlm} || � dS )zInstall the poll() reactor.r )�installReactorN)r Ztwisted.internet.mainr? )�pr? r r r �install� s rA )r> r3 �selectr r r r r r r1 r Zzope.interfacer Ztwisted.internetr Ztwisted.internet.interfacesr Ztwisted.pythonr r Z_PollLikeMixinr rA �__all__r r r r �<module> s $
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка