/usr/lib/python3/dist-packages/twisted/internet/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/internet/__pycache__/base.cpython-310.pyc (40870B)
o
b @ s U d Z ddlZddlZddlZddlmZmZ ddlmZm Z m
Z
ddl m Z ddl
mZ ddlmZmZmZmZmZmZmZmZmZmZmZmZ ddl m Z m Z dd l m Z m!Z!m"Z"m#Z#m$Z$m%Z% dd
l&m'Z(m)Z*m+Z, dd l-m.Z.m/Z/ dd l0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m
Z> dd
l?m@Z@ ddlAmBZBmCZC ddlDmEZE ddlFmGZGmHZI erddlJmKZK ddlAmLZL eGM rddlNmOZO ndZOe e3G dd dZPe e<G dd dZQe e<G dd dZRedef ZSeeSeeTdf eeUeTf f ZVedeeUeSeeTdf eeUeTf f ZWG d d d ZXe e7e8G d d d ZYed eeUeWf ZZeedef eeTdf eeUeTf f Z[e e6e:e>G d!d" d"eYZ\eGM rZe e\e9 e e2G d#d$ d$eZ]G d%d& d&e j^Z_G d'd( d(Z`g ZaeeU ebd)< dS )*z8
Very basic functionality for a Reactor implementation.
N)ABCabstractmethod)heapifyheappopheappush) format_stack) FrameType)
TYPE_CHECKINGAnyCallableDictListNewTypeOptionalSequenceSetTupleUnioncast)classImplements implementer)abstractdefererrorfdescmainthreads)ComplexResolverSimplifier GAIResolverSimpleResolverComplexifier)Deferred DeferredList)IAddress
IConnector IDelayedCallIHostnameResolver IProtocol IReactorCore IReactorPluggableNameResolverIReactorPluggableResolverIReactorThreads IReactorTimeIReadDescriptorIResolverSimpleIWriteDescriptor _ISupportsExitSignalCapturing)
ClientFactory)logreflect)Failure)platformseconds)Client)
threadable)
ThreadPoolc @ s e Zd ZU dZdZee ed< efde de
de f de e
deee
f d e
d gdf d
e
d gdf d e
g e f d dfd
dZd e fddZd$ddZde d dfddZde d dfddZd$ddZd efdd Zd e
d efd d Zd e
d efd d!Zd efd"d#ZdS )% DelayedCallFN_reprtimefunc.argskwcancelresetr5 returnc C s^ ||||f\| _ | _| _| _|| _|| _|| _d | _| _d| _ | j
r-t dd | _ dS dS )aR
@param time: Seconds from the epoch at which to call C{func}.
@param func: The callable to call.
@param args: The positional arguments to pass to the callable.
@param kw: The keyword arguments to pass to the callable.
@param cancel: A callable which will be called with this
DelayedCall before cancellation.
@param reset: A callable which will be called with this
DelayedCall after changing this DelayedCall's scheduled
execution time. The callable should adjust any necessary
scheduling details to ensure this DelayedCall is invoked
at the new appropriate time.
@param seconds: If provided, a no-argument callable which will be
used to determine the current time any time that information is
needed.
r N)
r; r< r= r> resetter cancellerr5 cancelledcalled delayed_timedebugr creator)selfr; r< r= r> r? r@ r5 rL 7/usr/lib/python3/dist-packages/twisted/internet/base.py__init__S s zDelayedCall.__init__c C s | j | j S )z
Return the time at which this call will fire
@return: The number of seconds after the epoch at which this call is
scheduled to be made.
r; rH rK rL rL rM getTimev s zDelayedCall.getTimec C sH | j rtj| jr tj| | d| _ | jr t| | _| ` | `
| ` dS )z
Unschedule this call
@raise AlreadyCancelled: Raised if this call has already been
unscheduled.
@raise AlreadyCalled: Raised if this call has already been made.
N) rF r AlreadyCancelledrG
AlreadyCalledrE rI reprr: r< r= r> rP rL rL rM r? s
zDelayedCall.cancelsecondsFromNowc C sX | j rtj| jr tj| | }|| jk r$d| _|| _| | dS || j | _dS )aY
Reschedule this call for a different time
@param secondsFromNow: The number of seconds from the time of the
C{reset} call at which this call will be scheduled.
@raise AlreadyCancelled: Raised if this call has been cancelled.
@raise AlreadyCalled: Raised if this call has already been made.
rB N) rF r rS rG rT r5 r; rH rD )rK rV newTimerL rL rM r@ s
zDelayedCall.reset secondsLaterc C sJ | j rtj| jr tj| j|7 _| jdk r#| | | dS dS )aQ
Reschedule this call for a later time
@param secondsLater: The number of seconds after the originally
scheduled time for which to reschedule this call.
@raise AlreadyCancelled: Raised if this call has been cancelled.
@raise AlreadyCalled: Raised if this call has already been made.
rB N)rF r rS rG rT rH activate_delayrD )rK rX rL rL rM delay s
zDelayedCall.delayc C s | j | j7 _ d| _d S )NrB rO rP rL rL rM rY s
zDelayedCall.activate_delayc C s | j p| j S )zDetermine whether this call is still pending
@return: True if this call has not yet been made or cancelled,
False otherwise.
)rF rG rP rL rL rM active s zDelayedCall.activeotherc C s t |tr | j|jkS tS )z
Implement C{<=} operator between two L{DelayedCall} instances.
Comparison is based on the C{time} attribute (unadjusted by the
delayed time).
isinstancer9 r; NotImplementedrK r\ rL rL rM __le__
zDelayedCall.__le__c C s t |tr | j|jk S tS )z
Implement C{<} operator between two L{DelayedCall} instances.
Comparison is based on the C{time} attribute (unadjusted by the
delayed time).
r] r` rL rL rM __lt__ rb zDelayedCall.__lt__c C sV | j dur| j S t| dr@t| jdd}|du r5t| jdd}|dur5t| jdd}|dur5| d| }|du r?t| j}nd}| }dt| | j| | j | j
f g}|dur| d|d f | j r{|
d
d d | j D | jr{|
d
| jr|
d
d
d | j D |
d | jr|
dd| j |
d d|S )z
Implement C{repr()} for L{DelayedCall} instances.
@returns: String containing details of the L{DelayedCall}.
Nr< __qualname____name__im_class.z. s z(DelayedCall.__repr__..c S s$ g | ]\}}| d t | qS )=rj )rl kvrL rL rM rn s $ )z
traceback at creation:
%sz > )r: hasattrgetattrr< r2 rk r5 idr; rG rF extendr= appendjoinr> itemsrI rJ )rK r< imClassnowLrL rL rM __repr__ sH
zDelayedCall.__repr__rA N)re
__module__rd rI r: r str__annotations__runtimeSecondsfloatr r
r objectr rN rQ r? r@ rZ rY boolr[ ra rc r rL rL rL rM r9 K s<
#
r9 c @ s e Zd ZdZdddZded edefd
d Zded ee ddfd
dZ deded ee ddfddZ
ddede e dee fddZ
dS )ThreadedResolvera
L{ThreadedResolver} uses a reactor, a threadpool, and
L{socket.gethostbyname} to perform name lookups without blocking the
reactor thread. It also supports timeouts indepedently from whatever
timeout logic L{socket.gethostbyname} might have.
@ivar reactor: The reactor the threadpool of which will be used to call
L{socket.gethostbyname} and the I/O thread of which the result will be
delivered.
reactor ReactorBaserA Nc C s || _ i | _d S N)r _runningQueries)rK r rL rL rM rN s zThreadedResolver.__init__nameerrc C s t d|d| }t|S )Naddress z not found: )r DNSLookupErrorr3 )rK r r lookupErrorrL rL rM _fail& s zThreadedResolver._faillookupDeferredc C s, | j | \}}| j |= || |d d S )Nz
timeout error)r errbackr )rK r r userDeferred
cancelCallrL rL rM _cleanup* s zThreadedResolver._cleanupresultc C sj z | j | \}}W n
ty Y d S w | j |= | t|tr.|| || d S || d S r ) r KeyErrorr? r^ r3 r r getErrorMessagecallback)rK r r r r r rL rL rM
_checkTimeout/ s
z ThreadedResolver._checkTimeoutrR - timeoutc C st |rt |}nd}t }t| jtt| j tj |}tt
| j || j ||}||f| j
|< || j|| |S )a1
See L{twisted.internet.interfaces.IResolverSimple.getHostByName}.
Note that the elements of C{timeout} are summed and the result is used
as a timeout for the lookup. Any intermediate timeout or retry logic
is left up to the platform via L{socket.gethostbyname}.
< )sumr r deferToThreadPoolr r r*
getThreadPoolsocket
gethostbynamer+ callLaterr r addBothr )rK r r timeoutDelayr r r rL rL rM
getHostByName? s
z ThreadedResolver.getHostByName)r r rA Nr )re r rd __doc__rN r r3 r r r r r intr rL rL rL rM r s,
r c @ s. e Zd Z ddedee dee fddZdS ) BlockingResolverr r r rA c C sL zt |}W n ty d|d}t|}t| Y S w t|S )Nr z
not found)r r OSErrorr r r failsucceed)rK r r addressmsgr rL rL rM r ^ s
z BlockingResolver.getHostByNameNr )re r rd r r r r r rL rL rL rM r \ s r . _ThreePhaseEventTriggerHandlec
@ s e Zd ZdZdddZdededed edef
d
d Z d eddfd
dZ
d eddfddZ d eddfddZ dddZ
deddfddZdS )_ThreePhaseEventa
Collection of callables (with arguments) which can be invoked as a group in
a particular order.
This provides the underlying implementation for the reactor's system event
triggers. An instance of this class tracks triggers for all phases of a
single type of event.
@ivar before: A list of the before-phase triggers containing three-tuples
of a callable, a tuple of positional arguments, and a dict of keyword
arguments
@ivar finishedBefore: A list of the before-phase triggers which have
already been executed. This is only populated in the C{'BEFORE'} state.
@ivar during: A list of the during-phase triggers containing three-tuples
of a callable, a tuple of positional arguments, and a dict of keyword
arguments
@ivar after: A list of the after-phase triggers containing three-tuples
of a callable, a tuple of positional arguments, and a dict of keyword
arguments
@ivar state: A string indicating what is currently going on with this
object. One of C{'BASE'} (for when nothing in particular is happening;
this is the initial value), C{'BEFORE'} (when the before-phase triggers
are in the process of being executed).
rA Nc C s g | _ g | _g | _d| _d S )NBASE)beforeduringafterstaterP rL rL rM rN s
z_ThreePhaseEvent.__init__phasecallabler= kwargsc O s6 |dvrt dt| ||||f t||||fS )a
Add a trigger to the indicate phase.
@param phase: One of C{'before'}, C{'during'}, or C{'after'}.
@param callable: An object to be called when this event is triggered.
@param args: Positional arguments to pass to C{callable}.
@param kwargs: Keyword arguments to pass to C{callable}.
@return: An opaque handle which may be passed to L{removeTrigger} to
reverse the effects of calling this method.
r r r
invalid phase)r rv ry r )rK r r r= r rL rL rM
addTrigger s z_ThreePhaseEvent.addTriggerhandlec C s t | d| j | dS )aS
Remove a previously added trigger callable.
@param handle: An object previously returned by L{addTrigger}. The
trigger added by that call will be removed.
@raise ValueError: If the trigger associated with C{handle} has already
been removed or if C{handle} is not a valid handle.
removeTrigger_N)rv r )rK r rL rL rM
removeTrigger s
z _ThreePhaseEvent.removeTriggerc C sV z|\}}}}W n
t tfy tdw |dvr tdt| ||||f dS )zN
Just try to remove the trigger.
@see: removeTrigger
zinvalid trigger handler r N) TypeError
ValueErrorr rv removerK r r r r= r rL rL rM removeTrigger_BASE s z#_ThreePhaseEvent.removeTrigger_BASEc C sP |\}}}}|dkr| |S |||f| jv r!tjdtdd dS | | dS )z
Remove the trigger if it has yet to be executed, otherwise emit a
warning that in the future an exception will be raised when removing an
already-executed trigger.
@see: removeTrigger
r zdRemoving already-fired system event triggers will raise an exception in a future version of Twisted.r )category
stacklevelN)r finishedBeforewarningswarnDeprecationWarningr rL rL rM removeTrigger_BEFORE s
z%_ThreePhaseEvent.removeTrigger_BEFOREc C s d| _ g | _g }| jrA| jd\}}}| j|||f z ||i |}W n
ty3 t Y n w t|t r>|| | js t
| | j dS )z8
Call the triggers added to this event.
BEFOREr N)
r r r popry
BaseExceptionr1 r r^ r r! addCallback_continueFiring)rK
beforeResultsr r= r r rL rL rM fireEvent s
z_ThreePhaseEvent.fireEventignoredc C sh d| _ g | _| j| jfD ]%}|r1|d\}}}z ||i | W n
ty. t Y nw |sq dS )zJ
Call the during and after phase triggers for this event.
r r N)r r r r r r r1 r )rK r r r r= r rL rL rM r s z _ThreePhaseEvent._continueFiringr )re r rd r rN r _ThreePhaseEventTriggerCallabler r r r r r r r rL rL rL rM r u s&
r c @ sf e Zd ZU dZe Zeed< eeZ e
ed< dedefddZ de
de
fddZ e
de
fd d
Zd S ) PluggableResolverMixinz
A mixin which implements the pluggable resolver reactor interfaces.
@ivar resolver: The installed L{IResolverSimple}.
@ivar _nameResolver: The installed L{IHostnameResolver}.
resolver
_nameResolverrA c C s( t |sJ | j}|| _t|| _|S )z
See L{IReactorPluggableResolver}.
@param resolver: see L{IReactorPluggableResolver}.
@return: see L{IReactorPluggableResolver}.
)r-
providedByr _SimpleResolverComplexifierr )rK r oldResolverrL rL rM installResolver s
z&PluggableResolverMixin.installResolverc C s | j }|| _ t|| _|S )z
See L{IReactorPluggableNameResolver}.
@param resolver: See L{IReactorPluggableNameResolver}.
@return: see L{IReactorPluggableNameResolver}.
)r _ComplexResolverSimplifierr )rK r previousNameResolverrL rL rM installNameResolver s
z*PluggableResolverMixin.installNameResolverc C s | j S )zd
Implementation of read-only
L{IReactorPluggableNameResolver.nameResolver}.
)r rP rL rL rM nameResolver, s z#PluggableResolverMixin.nameResolverN)re r rd r r r r- r r r r% r r propertyr rL rL rL rM r s
r _SystemEventIDc s e Zd ZdZdZdZdZdZdZdZ do fdd Z dZ
dod d
Z dod d Z d
e
e ddfddZdeddfddZdeddfddZdeddfddZdeddfddZdeeeef fddZdee fd d Zdee fd d Z dpd!ed"e e de e fd#d$Z dod%d&Z dod'd(Z!dqd)e d*e
e" ddfd+d,Z#dqd)e d*e
e" ddfd-d.Z$dqd)e d*e
e" ddfd/d0Z%dod1d2Z&drd
eddfd4d5Z'd6eddfd7d8Z(d9ed6ed:e)d;e*f dd?Z-d@e,ddfdAdBZ.d:e)d;e*f de?@ reAdusaJ dZBdZCdZDdod[d\ZEd]e)d;e*f d c O sb t |s J | d|dksJ | dt| | |||| j| j| jd}| j| |S )zI
See twisted.internet.interfaces.IReactorTime.callLater.
r- r z* is not greater than or equal to 0 seconds)r5 )r. r r9 r5 _cancelCallLater_moveCallLaterSoonerr ry )rK rZ r r= r> delayedCallrL rL rM r ^ s
zReactorBase.callLaterr: c C sv | j }z-||}|| }|dkr*|d d }|| |kr n || ||< |}|dks|||< W d S ty: Y d S w )Nr rR )r indexr )rK r: heapposeltparentrL rL rM r9 r s
z ReactorBase._moveCallLaterSoonerc C s | j d7 _ d S NrR )r )rK r: rL rL rM r8 s z ReactorBase._cancelCallLaterc C s dd | j | j D S )zQ
See L{twisted.internet.interfaces.IReactorTime.getDelayedCalls}
c S g | ]}|j s|qS rL rF rl xrL rL rM rn s z/ReactorBase.getDelayedCalls..)r r rP rL rL rM getDelayedCalls s
zReactorBase.getDelayedCallsc C s@ | j D ]}|jr| jd8 _q| t| j| qg | _ d S rA )r rF r rY r r )rK callrL rL rM _insertNewDelayedCalls s
z"ReactorBase._insertNewDelayedCallsc C s: | | js dS | jd j| }d}tdt||S )z
Determine the longest time the reactor may sleep (waiting on I/O
notification, perhaps) before it must wake up to service a time-related
event.
@return: The maximum number of seconds the reactor may sleep.
Nr i )rH r r; r5 maxmin)rK rZ longestrL rL rM r s zReactorBase.timeoutc C s | j rAd}t| j }| j D ]&\}}}z ||i | W n
ty( t Y nw |d7 }||kr3 nq
| j d|= | j rA| | | }| jr| jd j |krt
| j}|j rd| j d8 _ qI|j
dkrt| t| j| qIzd|_|j|ji |j W n3 ty t t|drd}|d7 }|d7 }|d |j dd
7 }|d7 }t| Y nw | jr| jd j |ksT| j d kr| j t| jd? krd| _ d d
| jD | _t| j | j rd| _ | d dS dS )z.
Run all pending timed calls.
r rR NrB rJ
z? C: previous exception occurred in a DelayedCall created here:
z C:rt z
C:2 c S rB rL rC rD rL rL rM rn s
z/ReactorBase.runUntilCurrent..Fr ) r lenr r1 r r rH r5 r r; r rF r rH rY r rG r< r= r> deferrru rz rJ rstripreplacer r r r, ) rK counttotalfar> r} rG rm rL rL rM r' sn
zReactorBase.runUntilCurrentc C s | t| | j d| _d S )NT)r _GAIResolverr usingThreadsrP rL rL rM r s
zReactorBase._initThreadsrT c O s4 t |s J | d| j|||f | dS )zl
See
L{twisted.internet.interfaces.IReactorFromThreads.callFromThread}.
r- N)r r ry r rK rT r= r rL rL rM r s zReactorBase.callFromThreadc C s4 t ddd| _| | jj| _| dd| j| _dS )zO
Create the threadpool accessible with callFromThread.
r
r r r N)r8
threadpoolr1 start_threadpoolStartupIDr _stopThreadPoolthreadpoolShutdownIDrP rL rL rM _initThreadPool s
zReactorBase._initThreadPoolc C d S r rL rP rL rL rM _uninstallHandler$ s z ReactorBase._uninstallHandlerc C sj | j | jg}td|D ]}z| | W q ty Y q w d| _ d| _| jdus+J | j d| _dS )a4
Stop the reactor threadpool. This method is only valid if there
is currently a threadpool (created by L{_initThreadPool}). It
is not intended to be called directly; instead, it will be
called by a shutdown trigger created in L{_initThreadPool}.
N)r\ r^ filterr0 r rZ r )rK triggerstriggerrL rL rM r] ' s
zReactorBase._stopThreadPoolc C s& | j du r| | j dusJ | j S )z[
See L{twisted.internet.interfaces.IReactorThreads.getThreadPool}.
N)rZ r_ rP rL rL rM r : s
zReactorBase.getThreadPool _callablec O s | j|g|R i | dS )z\
See L{twisted.internet.interfaces.IReactorInThreads.callInThread}.
N)r callInThread)rK re r= r rL rL rM rf F s zReactorBase.callInThreadsizec C s | j|d dS )zc
See L{twisted.internet.interfaces.IReactorThreads.suggestThreadPoolSize}.
)
maxthreadsN)r adjustPoolsize)rK rg rL rL rM suggestThreadPoolSizeN s z!ReactorBase.suggestThreadPoolSizec O s, t |s J | d| j|||f d S )Nr- )r r ry rX rL rL rM r V s r r r )rB )Nre r rd r r4 r installedrW r rN _lockr r r r r r, r
r. r
r r r
r r r r r r r r r r r r r r! r" r r( r, r r
r r r r0 r1 r6 r r7 staticmethodr r5 r9 r r9 r8 r$ rF rH r r' r4 r r8 rZ r\ r^ r r r_ ra r] r rf rj
__classcell__rL rL r rM r 9 s
D
r c @ s e Zd ZdZdZdZdedededdfdd Z d!d
d Z
e d"d
dZ d!ddZ
d!ddZd!ddZdedee fddZdeddfddZdeddfdd Zdefd d Zdefd d ZdS )#
BaseConnectorzm
Basic implementation of L{IConnector}.
State can be: "connecting", "connected", "disconnected"
Nr factoryr r rA c C s d| _ || _|| _|| _d S )N disconnected)r r rp r )rK rp r r rL rL rM rN m s
zBaseConnector.__init__c C s@ | j dkr | dS | j dkr | jdusJ | j dS dS )z!Disconnect whatever our state is.
connecting connectedN)r stopConnecting transportloseConnectionrP rL rL rM
disconnectu s
zBaseConnector.disconnectr6 c C r` r rL rP rL rL rM _makeTransport} s z BaseConnector._makeTransportc C sn | j dkr tdd| _ | js| j d| _| | _| jdur/| j | j| jj
t | _
| j| dS )z"Start connection to remote server.rq zcan't connect in this staterr rR N)r RuntimeErrorfactoryStartedrp doStartrx ru r r r failIfNotConnectedr TimeoutError timeoutIDstartedConnectingrP rL rL rM connect s
zBaseConnector.connectc C s@ | j dkr
td| jdusJ d| _ | jt | `dS )zStop attempting to connect.rr zwe're not trying to connectNrq )r r NotConnectingErrorru r| UserErrorrP rL rL rM rt s
z BaseConnector.stopConnectingc C s8 | j d urz| j W n ty Y nw | ` d S d S r )r~ r? r rP rL rL rM
cancelTimeout s
zBaseConnector.cancelTimeoutaddrc C s d| _ | | j|S )Nrs )r r rp
buildProtocol)rK r rL rL rM r s zBaseConnector.buildProtocolreasonc C sD | d | _d| _| j| | | jdkr | j d| _d S d S Nrq r )r ru r rp clientConnectionFaileddoStoprz rK r rL rL rM connectionFailed s
z BaseConnector.connectionFailedc C s6 d| _ | j| | | j dkr| j d| _d S d S r )r rp clientConnectionLostr rz r rL rL rM r$ s
z BaseConnector.connectionLostc C r )Nz! did not implement getDestinationr rP rL rL rM getDestination r z BaseConnector.getDestinationc C s" d t| jt| | j| S )Nz <{} instance at 0x{:x} {} {}>)formatr2 r r rw r r rP rL rL rM r s
zBaseConnector.__repr__r )rA r6 )re r rd r r~ rz r0 r r rN rw r rx r rt r r" r r& r r3 r r$ r r r rL rL rL rM ro b s0
ro c @ sP e Zd ZU dZdZejed< dZej ed< dejfddZ
de e fdd Z
dS )
BasePortziBasic implementation of a ListeningPort.
Note: This does not actually implement IListeningPort.
N
addressFamily
socketTyperA c C s, t | j| j}|d t| |S )NF)r r r setblockingr _setCloseOnExecfileno)rK srL rL rM createInternetSocket s
z BasePort.createInternetSocketc C s t dt| j )zRaises a RuntimeErrorzdoWrite called on a %s)ry r2 r r rP rL rL rM doWrite s zBasePort.doWrite)re r rd r r r
AddressFamilyr r
SocketKindr r r3 r rL rL rL rM r s
r c @ sZ e Zd ZdZdZdddZddeddfd d
Zdd d Zddeddfd
dZ dddZ
dS )_SignalReactorMixina!
Private mixin to manage signals: it installs signal handlers at start time,
and define run method.
It can only be used mixed in with L{ReactorBase}, and has to be defined
first in the inheritance (so that method resolution order finds
startRunning first).
@ivar _installSignalHandlers: A flag which indicates whether any signal
handlers will be installed during startup. This includes handlers for
SIGCHLD to monitor child processes, and SIGINT, SIGTERM, and SIGBREAK
to stop the reactor.
FrA Nc C s zddl }W n ty td Y dS w tt| }||j|jkr,| |j|j | |j
|j t |dd}|durG| ||j
dS dS )zI
Install the signal handlers for the Twisted event loop.
r NzEWarning: signal module unavailable -- not installing signal handlers.SIGBREAK)signal ImportErrorr1 r r r getsignalSIGINTdefault_int_handlerr SIGTERMr" rv r! )rK r reactorBaseSelfr rL rL rM _handleSignals s
z"_SignalReactorMixin._handleSignalsTinstallSignalHandlersc C s || _ ttt| dS )aB
Extend the base implementation in order to remember whether signal
handlers should be installed later.
@param installSignalHandlers: A flag which, if set, indicates that
handlers for a number of (implementation-defined) signals should be
installed during startup.
N)_installSignalHandlersr r6 r rK r rL rL rM r6 s z _SignalReactorMixin.startRunningc C s& t tt | | jr| dS dS )z
Extend the base implementation by also installing signal handlers, if
C{self._installSignalHandlers} is true.
N)r r r r r rP rL rL rM r s z'_SignalReactorMixin._reallyStartRunningc C s | j |d | d S )N)r )r6 mainLoopr rL rL rM r7 ! s z_SignalReactorMixin.runc C s t t| }|jr?z|jr!| | }|jo|}|| |js W n ty4 t d t
Y nw t d |jsd S d S )Nz Unexpected error in main loop.zMain loop terminated.) r r r r' r r r r r1 r r )rK r t2trL rL rM r % s
z _SignalReactorMixin.mainLoopr )T) re r rd r r r r r6 r r7 r rL rL rL rM r s
r __all__)cr r. r r abcr r heapqr r r tracebackr typesr typingr r
r r r
r r r r r r r zope.interfacer r twisted.internetr r r r r r twisted.internet._resolverr r r rV r r twisted.internet.deferr r! twisted.internet.interfacesr" r# r$ r% r& r' r( r) r* r+ r, r- r. r/ twisted.internet.protocolr0 twisted.pythonr1 r2 twisted.python.failurer3 twisted.python.runtimer4 r5 r twisted.internet.tcpr6 r7 r twisted.python.threadpoolr8 r9 r r r r r _ThreePhaseEventTriggerr r r r _ThreadCallr ro FileDescriptorr r r r rL rL rL rM st 8 @ HH 1&
(
e\