/usr/lib/python3/dist-packages/twisted/internet/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/internet/__pycache__/selectreactor.cpython-310.pyc (5303B)
o
b @ s U d Z ddlZddlZddlmZmZ ddlmZ ddlm Z ddl
m Z ddl m
Z
ddlmZ dd lmZ dd
lmZ dd d Zed
krIeZnejZzddlmZ W n eye eZe e ed< Y nw eZe eG dd de
j eZ dd Z dgZ dS )z
Select reactor
N)EBADFEINTR)sleep)Type) implementer) posixbase)
IReactorFDSet)log) platformTypec C sj | s|s|du r d}nt |d}t| g g g fS |du s!|dkr#d}t| |||\} }}| || g fS )zWin32 select wrapper.Ng{Gz?gMbP?g ?)minr select)rwetimeout r @/usr/lib/python3/dist-packages/twisted/internet/selectreactor.py win32select s
r win32)_ThreadedWin32EventsMixin
_extraBasec @ sl e Zd ZdZdd Zdd Zdd ZeZdd Zd
d Z d d
Z
dd Z dd Z dd Z
dd Zdd ZdS )
SelectReactora-
A select() based reactor - runs on all POSIX platforms and on Win32.
@ivar _reads: A set containing L{FileDescriptor} instances which will be
checked for read events.
@ivar _writes: A set containing L{FileDescriptor} instances which will be
checked for writability.
c C s t | _t | _tj| dS )zV
Initialize file descriptor tracking dictionaries and the base class.
N)set_reads_writesr PosixReactorBase__init__selfr r r r D s zSelectReactor.__init__c C s t d t| j}t| j}| j | j | j|f| j|ffD ]<\}}|D ]5}z
t|g|g|gd W n tyX } zt d| | ||d W Y d }~q)d }~ww | | q)q#d S )Nz1Malformed file descriptor found. Preening lists.r zbad descriptor %sF)
r msglistr r clearr Exception_disconnectSelectableadd)r readerswritersselSetselList
selectabler r r r _preenDescriptorsL s"
z SelectReactor._preenDescriptorsc
C s4 zt | j| jg |\}}}W n` ty | Y dS ty- t | Y dS tyn } z6|j d dv rI| jsH| jsHW Y d}~dS |j d t
krWW Y d}~dS |j d t kri| W Y d}~dS d}~ww | j }tj
}|d| jf|d| jffD ]\}} }
|D ]} | |
vrq|| || | qqdS )z
Run one iteration of the I/O monitor loop.
This will run all selectables who had input or output readiness
waiting for them.
Nr )r doReaddoWrite)_selectr r
ValueErrorr* TypeErrorr errOSErrorargsr r _doReadOrWritecallWithLogger) r r r
r ignoredse_drdw_logrun selectablesmethodfdsetr) r r r doSelect\ sB
zSelectReactor.doSelectc C sV zt || }W n ty t d }t Y nw |r)| |||dk d S d S )N r, )getattr
BaseExceptionsysexc_infor r1 r# )r r) r; whyr r r r4 s z SelectReactor._doReadOrWritec C | j | dS )zR
Add a FileDescriptor for notification of data available to read.
N)r r$ r readerr r r addReader zSelectReactor.addReaderc C rD )zS
Add a FileDescriptor for notification of data available to write.
N)r r$ r writerr r r addWriter rH zSelectReactor.addWriterc C rD )zQ
Remove a Selectable for notification of data available to read.
N)r discardrE r r r removeReader rH zSelectReactor.removeReaderc C rD )zR
Remove a Selectable for notification of data available to write.
N)r rL rI r r r removeWriter rH zSelectReactor.removeWriterc C s | | j| jS N)
_removeAllr r r r r r removeAll s zSelectReactor.removeAllc C
t | jS rO )r r r r r r
getReaders
zSelectReactor.getReadersc C rR rO )r r r r r r
getWriters rT zSelectReactor.getWritersN)__name__
__module__ __qualname____doc__r r* r= doIterationr4 rG rK rM rN rQ rS rU r r r r r 8 s
4 r c C s t } ddlm} || dS )zDConfigure the twisted mainloop to be run using the select() reactor.r )installReactorN)r twisted.internet.mainr[ )reactorr[ r r r install s r^ rO ) rY r rA errnor r timer typingr zope.interfacer twisted.internetr twisted.internet.interfacesr twisted.pythonr twisted.python.runtimer
r r. "twisted.internet.win32eventreactorr ImportErrorobjectr __annotations__r r r^ __all__r r r r
s4