/usr/lib/python3/dist-packages/twisted/internet/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/internet/__pycache__/posixbase.cpython-310.pyc (23457B)
o
bk @ s d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z m
Z
m Z m Z ddl
mZmZmZ ddlmZmZ ddlmZmZmZmZmZmZmZm Z m Z m Z ddl m Z m!Z! dd l"m#Z#m$Z$m%Z% dd
l&m'Z'm(Z( e)d Z*e)d Z+zdd
l,m-Z. W n e/y dZ-Y nw e.Z-zddl
m0Z1 W n e/y dZ0Y nw e1Z0e(dkZ2dZ3e2rddl
m4Z4m5Z5m6Z6m7Z7 dZ3e'8 rzddl9Z9dZ3W n e/y dZ9Y nw G dd de
Z:e e:G dd de$j;Z
e(dkre>Z?ne}, used to wake
up the main loop from another thread or a signal handler.
This is why we have wakeUp together with doRead
This is used by threads or signals to wake up the event loop.
c C dS )z:
Called when the event should be wake up.
N r' r' r' }, implemented
using a pair of sockets rather than pipes (due to the lack of support in
select() on Windows for pipes), used to wake up the main loop from
another thread.
r c C s || _ ttjtj}|tjtjd tttjtj }| d |
d | | |
\}}W d n1 sAw Y |d |d || _|| _| jj| _dS ) Initialize. )z 127.0.0.1r Nr )reactorsocketAF_INET SOCK_STREAM
setsockopt IPPROTO_TCP TCP_NODELAY
contextlibclosingbindlistenconnect getsocknameaccept setblockingrwfileno)selfr7 clientserverreader
clientaddrr' r' r( __init__r s"
z_SocketWaker.__init__c
C sP z t | jjd W dS ty' } z|jd tjkr W Y d}~dS d}~ww )z Send a byte to my connection. xr N)r untilConcludesrG sendOSErrorargserrnoWSAEWOULDBLOCKrI er' r' r( r) s z_SocketWaker.wakeUpc C s( z | j d W dS ty Y dS w )z4
Read some data from my connection.
N)rF recvrR rI r' r' r( r+ s
z_SocketWaker.doReadc C s | j | j d S N)rF closerG )rI r, r' r' r( r- s
z_SocketWaker.connectionLostN) r. r/ r0 r1 r2 rN r) r+ r- r' r' r' r( r4 g s r4 c @ s4 e Zd ZdZdZdZdZdd Zdd Zdd Z dS )
_FDWakera
The I{self-pipe trick}, used to wake
up the main loop from another thread or a signal handler.
L{_FDWaker} is a base class for waker implementations based on
writing to a pipe being monitored by the reactor.
@ivar o: The file descriptor for the end of the pipe which can be
written to wake up a reactor monitoring this waker.
@ivar i: The file descriptor which should be monitored in order to
be awoken by this waker.
r Nc sX | _ t \ _ _t j t j t j t j fdd _dS )r5 c s j S r[ )ir' rZ r' r( s z#_FDWaker.__init__..N) r7 ospiper^ or! setNonBlocking_setCloseOnExecrH rI r7 r' rZ r( rN s z_FDWaker.__init__c C s t | dd dS )zA
Read some bytes from the pipe and discard them.
c S s d S r[ r' )datar' r' r( r_ r* z!_FDWaker.doRead..N)r!
readFromFDrH rZ r' r' r( r+ s z_FDWaker.doReadc C sL t | dsdS | j| jfD ]}zt| W q
ty Y q
w | `| `dS )zClose both ends of my pipe.rb N)hasattrr^ rb r` r\ rR )rI r, fdr' r' r( r- s
z_FDWaker.connectionLost)
r. r/ r0 r1 r2 r^ rb rN r+ r- r' r' r' r( r] s
r] c @ e Zd ZdZdd ZdS )
_UnixWakerz
This class provides a simple interface to wake up the event loop.
This is used by threads or signals to wake up the event loop.
c
C s\ | j dur,z ttj| j d W dS ty+ } z|jtjkr W Y d}~dS d}~ww dS )z)Write one byte to the pipe, and flush it.NrO )rb r rP r` writerR rT EAGAINrV r' r' r( r) s
z_UnixWaker.wakeUpN)r. r/ r0 r1 r) r' r' r' r( rk s rk c @ s0 e Zd ZdZdd Zdd Zdd Zdd Zd
S )
_SIGCHLDWakerz}
L{_SIGCHLDWaker} can wake up a reactor whenever C{SIGCHLD} is
received.
@see: L{twisted.internet._signals}
c C s t | | d S r[ )r] rN re r' r' r( rN s z_SIGCHLDWaker.__init__c C s t | j dS )zJ
Install the handler necessary to make this waker active.
N)r installHandlerrb rZ r' r' r( install s z_SIGCHLDWaker.installc C s t d dS )zC
Remove the handler which makes this waker active.
N)r ro rZ r' r' r( uninstall s z_SIGCHLDWaker.uninstallc C s t | t dS )a
Having woken up the reactor in response to receipt of
C{SIGCHLD}, reap the process which exited.
This is called whenever the reactor notices the waker pipe is
writeable, which happens soon after any call to the C{wakeUp}
method.
N)r] r+ r" reapAllProcessesrZ r' r' r( r+ s
z_SIGCHLDWaker.doReadN)r. r/ r0 r1 rN rp rr r+ r' r' r' r( rn s rn c @ s< e Zd ZdZejee ejee ifddZ dS )_DisconnectSelectableMixinz>
Mixin providing the C{_disconnectSelectable} method.
c C sx | | ||j}|r-|r!|jtjkr!t|r!|| dS | | | | dS | | | t
| dS )z
Utility function for disconnecting a selectable.
Supports half-close notification, isRead should be boolean indicating
whether error resulted from doRead().
N) removeReaderget __class__r ConnectionDoner
providedByreadConnectionLost removeWriterr- r r3 )rI
selectablewhyisReadfaildictfr' r' r( _disconnectSelectable s
z0_DisconnectSelectableMixin._disconnectSelectableN)
r. r/ r0 r1 r rx r r3 ConnectionLostr r' r' r' r( rt s
rt c @ s e Zd ZU dZeZdd ZdZdd Zdd Z d i dddd
dfd d Z
d0ddZ d1ddZ d2ddZ
d3ddZd4dd Z d5d d ZerUejejejfZeej ed < nejejfZd d! Zd"d# Z d6d$d%Z d7d&d'Z d8d(d)Z d8d*d+Z d7d,d-Z d.d/ Z!dS )9PosixReactorBasez
A basis for reactors that use file descriptors.
@ivar _childWaker: L{None} or a reference to the L{_SIGCHLDWaker}
which is used to properly notice child process termination.
c C s4 | j s| | | _ | j| j | | j dS dS )z
Install a `waker' to allow threads and signals to wake up the IO thread.
We use the self-pipe trick (http://cr.yp.to/docs/selfpipe.html) to wake
the reactor. On Windows we use a pair of sockets.
N)waker
_wakerFactory_internalReadersadd addReaderrZ r' r' r( installWaker? s
z PosixReactorBase.installWakerNc C s^ t | tdkr+tr-| js t| | _| j| j | | j | j t
dS dS dS )z
Extend the basic signal handling logic to also support
handling SIGCHLD to know when to try to reap child processes.
r N) r _handleSignalsr processEnabled _childWakerrn r r r rp r" rs rZ r' r' r( r M s
z PosixReactorBase._handleSignalsc C s | j r
| j dS dS )a
If a child waker was created and installed, uninstall it now.
Since this disables reactor functionality and is only called
when the reactor is stopping, it doesn't provide any directly
useful functionality, but the cleanup of reactor-related
process-global state that it does helps in unit tests
involving multiple reactors and is generally just a nice
thing.
N)r rr rZ r' r' r( _uninstallHandler` s z"PosixReactorBase._uninstallHandlerr' r c
C s t dkr(|r| d urtdt| |||||||| S t| |||||||| S t dkr]|d ur4td|d ur rT r` r8 r typingr zope.interfacer r r r twisted.internetr r r twisted.internet.baser
r twisted.internet.interfacesr r
r r r r r r r r twisted.internet.mainr r twisted.pythonr r r twisted.python.runtimer r ConnectionFdescWentAway
_NO_FILENOr twisted.protocolsr _tls ImportErrorr _sslr r r r! r" r# isWindowsr r$ Loggerr4 r] rk r rn rt r r r getattr__all__r' r' r' r( s 0
30
$
& AI