| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/internet/__pycache__/ |
Upload File : |
o
�bB* �
@ s d Z ddlZddlZddlmZmZmZmZ ddlm Z m
Z
ddl m Z m
Z
ddlmZmZ zeed�Zeed�Zeed �Zeed
�Zeed �ZW n eyY Z zee��dZ[ww G d d
� d
e�Ze�ee� ee
e �G dd� de
j ��Z dd� Z ddgZ 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()
� N)� Attribute� Interface� declarations� implementer)�main� posixbase)�IReactorDaemonize�
IReactorFDSet)�failure�log� KQ_EV_ADD� KQ_EV_DELETE� KQ_EV_EOF�KQ_FILTER_READ�KQ_FILTER_WRITEc @ 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__)�self� _kqueueImplr r r r" Q 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 �_updateRegistratione s "z!KQueueReactor._updateRegistrationc C s | j �� d| _ dS )zA
Implement L{IReactorDaemonize.beforeDaemonize}.
N)r �close�r# r r r �beforeDaemonizem s
z KQueueReactor.beforeDaemonizec C sD | j �� | _| jD ] }| �|tt� q | jD ] }| �|tt� qdS )z@
Implement L{IReactorDaemonize.afterDaemonize}.
N) r r r r r) r r r r )r# r& r r r �afterDaemonize} s
�z KQueueReactor.afterDaemonizec C � |� � }|| jvrEz/z | �|tt� W n ty Y nw W || j|< | j�|� dS W || j|< | j�|� dS || j|< | j�|� w dS )z7
Implement L{IReactorFDSet.addReader}.
N)�filenor r) r r �OSErrorr �add)r# �readerr& r r r � addReader� �
��
�
��zKQueueReactor.addReaderc C r. )z7
Implement L{IReactorFDSet.addWriter}.
N)r/ r r) r r r0 r r1 )r# �writerr& r r r � addWriter� r4 zKQueueReactor.addWriterc C � d}z|� � }W n ty d}Y nw |dkr,| j�� D ] \}}||u r)d} nq dS || jv rW| j�|� || jvr@| j|= |sYz
| �|tt � W dS t
yV Y dS w dS dS )z:
Implement L{IReactorFDSet.removeReader}.
F���TN) r/ �
BaseExceptionr �itemsr �remover r) r r
r0 )r# r2 �wasLostr& �fdesr r r � removeReader� �2 ��
��zKQueueReactor.removeReaderc C r7 )z:
Implement L{IReactorFDSet.removeWriter}.
Fr8 TN) r/ r9 r r: r r; r r) r r
r0 )r# r5 r< r& r= r r r � removeWriter� r? zKQueueReactor.removeWriterc s, � � � fdd�� jD �� fdd�� jD ��S )z7
Implement L{IReactorFDSet.removeAll}.
c � g | ]}� j | �qS r �r ��.0r& r+ r r �
<listcomp>� � z+KQueueReactor.removeAll.<locals>.<listcomp>c rA r rB rC r+ r r rE � rF )�
_removeAllr r r+ r r+ r � removeAll� s �zKQueueReactor.removeAllc � � fdd�� j D �S )z8
Implement L{IReactorFDSet.getReaders}.
c rA r rB rC r+ r r rE � rF z,KQueueReactor.getReaders.<locals>.<listcomp>)r r+ r r+ r �
getReaders� � zKQueueReactor.getReadersc rI )z8
Implement L{IReactorFDSet.getWriters}.
c rA r rB rC r+ r r rE � rF z,KQueueReactor.getWriters.<locals>.<listcomp>)r r+ r r+ r �
getWriters� rK zKQueueReactor.getWritersc
C s� |du rd}z
| j �g t| j�|�}W n ty- } z|jtjkr(W Y d}~dS � d}~ww | j}|D ] }|j}z| j| }W n t yH Y q3w t
� |||||� q3dS )z1
Poll the kqueue for new events.
N� ) r r% �lenr r0 �errno�EINTR�_doWriteOrRead�ident�KeyErrorr �callWithLogger)r# �timeout�events�e�_drdw�eventr& �
selectabler r r �doKEvent� s( �� ��zKQueueReactor.doKEventc
C s� d}d}|j |j|j|jf\}}}} |t@ r |r | r tj}n6z"|�� dkr+d}tj }n|t
kr5d}|� � }|t kr?d}|�
� }W n tyS t�� }t�|d� Y nw |r_| �|||� dS dS )z�
Private method called when a FD is ready for reading, writing or was
lost. Do the work and raise errors where necessary.
NFr8 TzSAn exception was raised from application code while processing a reactor selectable)r' �flags�data�fflagsr r �CONNECTION_LOSTr/ r � _NO_FILEDESCr �doReadr �doWriter9 r
�Failurer �err�_disconnectSelectable)
r# rZ r& rY �why�inReadr' r\ r] r^ r r r rQ s< � � ��
�z KQueueReactor._doWriteOrReadN)r r r r �selectr" r) r, r- r3 r6 r> r@ rH rJ rL r[ rQ � doIterationr r r r r 6 s )r c C s t � } ddlm} || � dS )z'
Install the kqueue() reactor.
r )�installReactorN)r �twisted.internet.mainrj )�prj r r r �install: s rm ) r rO rh �zope.interfacer r r r �twisted.internetr r �twisted.internet.interfacesr r �twisted.pythonr
r �getattrr r
r r r �AttributeErrorrW � ImportErrorr �directlyProvidesr! r rm �__all__r r r r �<module> s2
��