/usr/lib/python3/dist-packages/twisted/internet/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/internet/__pycache__/kqreactor.cpython-310.pyc (8582B)
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 úà ó z+KQueueReactor.removeAll.
.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..)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..)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 Ú s2
€ÿ