/usr/lib/python3/dist-packages/twisted/internet/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/internet/__pycache__/epollreactor.cpython-310.pyc (6921B)
o
b"
@ s d Z ddlZddlZddlmZ ddlmZ ddlmZ ddl m
Z
ze edZ e edZ
e ed Ze ed
Ze ed ZW n eyM Z zeedZ[ww eeG d d
d
ejejZdd Zd
dgZdS )z
An epoll() 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 epollreactor
epollreactor.install()
N) implementer) posixbase)
IReactorFDSet)logepollEPOLLHUPEPOLLERREPOLLINEPOLLOUTc @ s| e Zd ZdZeeB ZeZe Z
dd Z dd Z dd Z
dd Zd
d Zd d
Zdd Zdd Zdd Zdd Zdd ZeZdS ) EPollReactora
A reactor that uses epoll(7).
@ivar _poller: A C{epoll} which will be used to check for I/O
readiness.
@ivar _selectables: A dictionary mapping integer file descriptors to
instances of C{FileDescriptor} which have been registered with the
reactor. All C{FileDescriptors} 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{_poller} for read readiness notifications
which will be dispatched to the corresponding C{FileDescriptor}
instances in C{_selectables}.
@ivar _writes: A set containing integer file descriptors. Values in this
set will be registered with C{_poller} for write readiness
notifications which will be dispatched to the corresponding
C{FileDescriptor} instances in C{_selectables}.
@ivar _continuousPolling: A L{_ContinuousPolling} instance, used to handle
file descriptors (e.g. filesystem files) that are not supported by
C{epoll(7)}.
c C s< t d| _t | _t | _i | _t| | _tj
| dS )zm
Initialize epoll object, file descriptor tracking dictionaries, and the
base class.
i N) r _pollerset_reads_writes _selectablesr _ContinuousPolling_continuousPollingPosixReactorBase__init__self r ?/usr/lib/python3/dist-packages/twisted/internet/epollreactor.pyr G s
zEPollReactor.__init__c C s\ | }||vr,|}||v r||O }| j|| n| j|| || |||< dS dS )z
Private method for adding a descriptor from the event loop.
It takes care of adding it if new or modifying it if already added
for another state (read -> read/write for example).
N)filenor modifyregisteradd) r xerprimaryother selectablesevent antieventfdflagsr r r _addV s
zEPollReactor._addc
C d z| || j| j| jtt W dS ty1 } z|jtjkr%| j
| n W Y d}~dS d}~ww )zR
Add a FileDescriptor for notification of data available to read.
N) r% r r r r r
OSErrorerrnoEPERMr addReader)r readerer r r r* p
zEPollReactor.addReaderc
C r& )zS
Add a FileDescriptor for notification of data available to write.
N) r% r r r r
r r' r( r) r addWriter)r writerr, r r r r. r- zEPollReactor.addWriterc
C sz | }|dkr| D ]
\}}||u r nq dS ||v r;||v r+|} | j|| n ||= | j| || dS dS )z
Private method for removing a descriptor from the event loop.
It does the inverse job of _add, and also add a check in case of the fd
has gone away.
N)r itemsr r
unregisterremove)
r r r r r r! r" r# fdesr$ r r r _remove s zEPollReactor._removec C : | j |r| j | dS | || j| j| jtt dS )zQ
Remove a Selectable for notification of data available to read.
N) r isReading removeReaderr5 r r r r r
)r r+ r r r r8 zEPollReactor.removeReaderc C r6 )zR
Remove a Selectable for notification of data available to write.
N) r isWriting removeWriterr5 r r r r
r )r r/ r r r r; r9 zEPollReactor.removeWriterc s6 fdd jD fdd jD j S )zD
Remove all selectables, and return a list of them.
c g | ]} j | qS r r .0r# r r r
z*EPollReactor.removeAll..c r< r r= r> r r r r@ rA )
_removeAllr r r removeAllr r r r rC s zEPollReactor.removeAllc fdd j D j S )Nc r< r r= r> r r r r@
z+EPollReactor.getReaders..)r r
getReadersr r r r rF
zEPollReactor.getReadersc rD )Nc r< r r= r> r r r r@ rE z+EPollReactor.getWriters..)r r
getWritersr r r r rH rG zEPollReactor.getWritersc
C s |du rd}z | j |t| j}W n ty, } z|jtjkr'W Y d}~dS d}~ww | j}|D ] \}}z| j| }W n tyF Y q2w t
||||| q2dS )z1
Poll the poller for new events.
Nr0 ) r polllenr r' r( EINTR_doReadOrWriteKeyErrorr callWithLogger)r timeoutlerr_drdwr# r!
selectabler r r doPoll s& zEPollReactor.doPollN)__name__
__module__ __qualname____doc__r r _POLL_DISCONNECTEDr _POLL_INr
_POLL_OUTr r% r* r. r5 r8 r; rC rF rH rT doIterationr r r r r % s" r c C s t } ddlm} || dS )z&
Install the epoll() reactor.
r )installReactorN)r twisted.internet.mainr] )pr] r r r install s r` )rX r( selectzope.interfacer twisted.internetr twisted.internet.interfacesr twisted.pythonr getattrr r r r r
AttributeErrorr, ImportErrorr _PollLikeMixinr r` __all__r r r r s,
T