File: //usr/lib/python3/dist-packages/twisted/internet/__pycache__/kqreactor.cpython-38.pyc
U
��W[4( � @ s� d Z ddlmZmZ ddlZddlZddlmZmZ ddlmZm Z m
Z
ddl m Z m
Z
mZmZ ddlmZmZ ddlmZmZ dd lmZmZ G d
d � d e�Ze
�ee� e ee�G d d
� d
ej��Z dd� Z d
dgZ dS )am
A kqueue()/kevent() based implementation of the Twisted main loop.
To use this reactor, start your application specifying the kqueue reactor::
twistd --reactor kqueue ...
To install the event loop from code (and you should do this before any
connections, listeners or connectors are added)::
from twisted.internet import kqreactor
kqreactor.install()
� )�division�absolute_importN)�KQ_FILTER_READ�KQ_FILTER_WRITE)� KQ_EV_DELETE� KQ_EV_ADD� KQ_EV_EOF)� implementer� declarations� Interface� Attribute)�main� posixbase)�
IReactorFDSet�IReactorDaemonize)�log�failurec @ s e Zd ZdZed�Zed�ZdS )�_IKQueuez2
An interface for KQueue implementations.
z An implementation of kqueue(2).z An implementation of kevent(2).N)�__name__�
__module__� __qualname__�__doc__r �kqueue�kevent� r r �</usr/lib/python3/dist-packages/twisted/internet/kqreactor.pyr # s r c @ s� e Zd ZdZefdd�Zdd� Zdd� Zdd � Zd
d � Z d d
� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� ZeZd S ) �
KQueueReactoram
A reactor that uses kqueue(2)/kevent(2) and relies on Python 2.6 or higher
which has built in support for kqueue in the select module.
@ivar _kq: A C{kqueue} which will be used to check for I/O readiness.
@ivar _impl: The implementation of L{_IKQueue} to use.
@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 set containing integer file descriptors. Values in this
set will be registered with C{_kq} for read readiness notifications
which will be dispatched to the corresponding L{FileDescriptor}
instances in C{_selectables}.
@ivar _writes: A set containing integer file descriptors. Values in this
set will be registered with C{_kq} for write readiness notifications
which will be dispatched to the corresponding L{FileDescriptor}
instances in C{_selectables}.
c C s8 || _ | j �� | _t� | _t� | _i | _tj� | � dS )a�
Initialize kqueue object, file descriptor tracking dictionaries, and
the base class.
See:
- http://docs.python.org/library/select.html
- www.freebsd.org/cgi/man.cgi?query=kqueue
- people.freebsd.org/~jlemon/papers/kqueue.pdf
@param _kqueueImpl: The implementation of L{_IKQueue} to use. A
hook for testing.
N)
�_implr �_kq�set�_reads�_writes� _selectablesr �PosixReactorBase�__init__)�selfZ _kqueueImplr r r r$ I s
zKQueueReactor.__init__c C s" | j �| j�|||�gdd� dS )z�
Private method for changing kqueue registration on a given FD
filtering for events given filter/op. This will never block and
returns nothing.
r N)r �controlr r )r% �fd�filter�opr r r �_updateRegistration^ s z!KQueueReactor._updateRegistrationc C s | j �� d| _ dS )zA
Implement L{IReactorDaemonize.beforeDaemonize}.
N)r �close�r% r r r �beforeDaemonizeg s
z KQueueReactor.beforeDaemonizec C sD | j �� | _| jD ]}| �|tt� q| jD ]}| �|tt� q,dS )z@
Implement L{IReactorDaemonize.afterDaemonize}.
N) r r r r r* r r r! r )r% r' r r r �afterDaemonizex s
z KQueueReactor.afterDaemonizec C s\ |� � }|| jkrXz,z| �|tt� W n tk
r: Y nX W 5 || j|< | j�|� X dS )z7
Implement L{IReactorFDSet.addReader}.
N)�filenor r" �addr* r r �OSError)r% �readerr' r r r � addReader� s
zKQueueReactor.addReaderc C s\ |� � }|| jkrXz,z| �|tt� W n tk
r: Y nX W 5 || j|< | j�|� X dS )z7
Implement L{IReactorFDSet.addWriter}.
N)r/ r! r" r0 r* r r r1 )r% �writerr' r r r � addWriter� s
zKQueueReactor.addWriterc C s� d}z |� � }W n d}Y nX |dkrR| j�� D ]\}}||kr4d} qRq4dS || jkr�| j�|� || jkrz| j|= |s�z| �|tt� W n t k
r� Y nX dS )z:
Implement L{IReactorFDSet.removeReader}.
F���TN)
r/ r" �itemsr �remover! r* r r r1 )r% r2 �wasLostr' �fdesr r r � removeReader� s(
zKQueueReactor.removeReaderc C s� d}z |� � }W n d}Y nX |dkrR| j�� D ]\}}||kr4d} qRq4dS || jkr�| j�|� || jkrz| j|= |s�z| �|tt� W n t k
r� Y nX dS )z:
Implement L{IReactorFDSet.removeWriter}.
Fr6 TN)
r/ r" r7 r! r8 r r* r r r1 )r% r4 r9 r' r: r r r � removeWriter� s(
zKQueueReactor.removeWriterc s, � � � fdd�� jD �� fdd�� jD ��S )z7
Implement L{IReactorFDSet.removeAll}.
c s g | ]}� j | �qS r �r" ��.0r' r, r r �
<listcomp>� s z+KQueueReactor.removeAll.<locals>.<listcomp>c s g | ]}� j | �qS r r= r> r, r r r@ � s )Z
_removeAllr r! r, r r, r � removeAll� s �zKQueueReactor.removeAllc s � fdd�� j D �S )z8
Implement L{IReactorFDSet.getReaders}.
c s g | ]}� j | �qS r r= r> r, r r r@ � s z,KQueueReactor.getReaders.<locals>.<listcomp>)r r, r r, r �
getReaders� s zKQueueReactor.getReadersc s � fdd�� j D �S )z8
Implement L{IReactorFDSet.getWriters}.
c s g | ]}� j | �qS r r= r> r, r r r@ � s z,KQueueReactor.getWriters.<locals>.<listcomp>)r! r, r r, r �
getWriters� s zKQueueReactor.getWritersc
C s� |dkr d}z| j �g t| j�|�}W n: tk
r` } z |jtjkrNW Y �
dS � W 5 d}~X Y nX | j}|D ]D}|j}z| j| }W n t k
r� Y qlY qlX t
� |||||� qldS )z1
Poll the kqueue for new events.
N� ) r r& �lenr" r1 �errnoZEINTR�_doWriteOrReadZident�KeyErrorr ZcallWithLogger)r% ZtimeoutZevents�eZ_drdw�eventr' �
selectabler r r �doKEvent� s
zKQueueReactor.doKEventc
C s� d}d}|j |j|j|jf\}}}} |t@ r<|r<| r<tj}nfzD|�� dkrVd}tj }n(|t
krjd}|� � }|t kr~d}|�
� }W n t�� }t�|d� Y nX |r�| �|||� dS )z�
Private method called when a FD is ready for reading, writing or was
lost. Do the work and raise errors where necessary.
NFr6 TzSAn exception was raised from application code while processing a reactor selectable)r( �flags�data�fflagsr r
ZCONNECTION_LOSTr/ r Z _NO_FILEDESCr ZdoReadr ZdoWriter ZFailurer �errZ_disconnectSelectable)
r% rK r' rJ ZwhyZinReadr( rM rN rO r r r rG s0 � z KQueueReactor._doWriteOrReadN)r r r r �selectr$ r* r- r. r3 r5 r; r< rA rB rC rL rG Z doIterationr r r r r . s "r c C s t � } ddlm} || � dS )z'
Install the kqueue() reactor.
r )�installReactorN)r Ztwisted.internet.mainrR )�prR r r r �install7 s rT ) r Z
__future__r r rF rQ r r r r r Zzope.interfacer r
r r Ztwisted.internetr
r Ztwisted.internet.interfacesr r Ztwisted.pythonr r r ZdirectlyProvidesr# r rT �__all__r r r r �<module> s"