h& %SrSSKrSSKrSSKrSSKJrJr SSKJrJ r J r SSK J r SSK Jr SSKJrJrJrJrJrJrJrJrJrJrJrJr SSKJrJr SS KJ r J!r!J"r"J#r#J$r$J%r% SS K&J'r(J)r*J+r, SS K-J.r.J/r/ SS K0J1r1J2r2J3r3J4r4J5r5J6r6J7r7J8r8J9r9J:r:J;r;Jr>J?r? SS K@JArA SSKBJCrC SSKDJErE SSKFJGrG SSKHJIrJ SSKKJLrLJMrN SSKOJPrPJQrQJRrR \(aSSKSJTrT SSKDJUrU \LR"5(aSSKWJXrX OSrX\C"5rY\YRS5r[\YRS5r\\YRS5r]\"\35"SS55r^\"\=5"SS55r_\"\=5"SS 55r`\S!\4ra\\a\\bS!4\\c\b44rd\"S"\\c\a\\bS!4\\c\b445re"S#S$5rf\"\8\95"S%S&55rg\"S'\\c\e45rh\\S!\4\\bS!4\\c\b44ri\YRS(5rj\"\6\;\?5"S)S*\g55rk\LR"5(a \"\k\:5 \"\25"S+S,\55rl"S-S.\ R5rn/ro\\c\pS/'g)0z8 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 IReactorCoreIReactorFromThreadsIReactorPluggableNameResolverIReactorPluggableResolverIReactorThreads IReactorTimeIReadDescriptorIResolverSimpleIWriteDescriptor_ISupportsExitSignalCapturing) ClientFactory)Logger)reflect)Failure)callWithLogger)platformseconds)SignalHandling_WithoutSignalHandling_WithSignalHandling)Client) threadable) ThreadPoolzUnexpected error in main loopzwhile calling from threadz*While calling system event trigger handlerc:\rSrSr%SrSr\\\S'Sr \\ \\S'\ 4S\ S\ S\4S \ \S \\\4S \ S/S4S \ S/S4S \ /\ 4SS4SjjrS\ 4SjrSSjrS\ SS4SjrS\ SS4SjrSSjrS\4SjrSSS\4SjrSSS\4SjrS\4SjrSrg) DelayedCallWFN_reprcreatortimefunc.argskwcancelresetr8returncXX44uUlUlUlUlX`lXPlXplS=UlUlSUl UR(a[5SSUl gg)a @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. rN) rErFrGrHresetter cancellerr8 cancelledcalled delayed_timedebugrrD)selfrErFrGrHrIrJr8s \/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/internet/base.py__init__DelayedCall.__init__as`448t3G0 49di  '(( ::'>#2.DL c4URUR-$)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. rErSrUs rVgetTimeDelayedCall.getTimesyy4,,,,rYcUR(a[ReUR(a[ReUR U5 SUlUR (a[U5UlU? U? U? g)z Unschedule this call @raise AlreadyCancelled: Raised if this call has already been unscheduled. @raise AlreadyCalled: Raised if this call has already been made. r9N) rQrAlreadyCancelledrR AlreadyCalledrPrTreprrCrFrGrHr\s rVrIDelayedCall.cancels\ >>(( ( [[%% % NN4 DNzz!$Z  49dgrYsecondsFromNowc0UR(a[ReUR(a[ReUR 5U-nX R :aSUlX lURU5 gX R - Ulg)a) 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. rMN) rQrr`rRrar8rErSrO)rUrdnewTimes rVrJDelayedCall.resetsl >>(( ( [[%% %lln~5G"$'!#  d#$+ii$7!rY secondsLatercUR(a[ReUR(a[ReU=R U- slUR S:a"UR 5 URU5 gg)a! 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. rMN)rQrr`rRrarSactivate_delayrO)rUrhs rVdelayDelayedCall.delaysf >>(( ( [[%% %    -   3&##% d#'rYcPU=RUR- slSUlg)NrMr[r\s rVrjDelayedCall.activate_delays T&&& rYcJUR=(d UR(+$)zDetermine whether this call is still pending @return: True if this call has not yet been made or cancelled, False otherwise. )rQrRr\s rVactiveDelayedCall.actives NN1dkk22rYotherc4URUR:*$)z Implement C{<=} operator between two L{DelayedCall} instances. Comparison is based on the C{time} attribute (unadjusted by the delayed time). rErUrrs rV__le__DelayedCall.__le__syyEJJ&&rYc4URUR:$)z Implement C{<} operator between two L{DelayedCall} instances. Comparison is based on the C{time} attribute (unadjusted by the delayed time). rtrus rV__lt__DelayedCall.__lt__syy5::%%rYc URb UR$[US5(ay[URSS5nUc;[URSS5nUb![URSS5nUbUSU3nUc [R "UR5nOSnUR 5nS[U5URU- URUR4-/nUGbURSUS 45 UR(aqURS RURVs/sHn[R "U5PM sn55 UR(aURS 5 UR(afURS RURR!5VVs/sH upgUS [R "U53PM" snn55 URS 5 UR"b-URS SRUR"5-5 URS5 SRU5$s snfs snnf)zo Implement C{repr()} for L{DelayedCall} instances. @returns: String containing details of the L{DelayedCall}. NrF __qualname____name__im_class.z.)rChasattrgetattrrFr4 safe_reprr8idrErRrQextendrGappendjoinrHitemsrD)rUrFimClassnowLekvs rV__repr__DelayedCall.__repr__s :: !::  4 499nd;D|tyy*d;#%diiTBG*")!D62|((3Dlln <$xS$++t~~F G    HHc4% &yy$))#L)QG$5$5a$8)#LMN77HHTNwwIIEIWW]]_U_6AA3a 1 1! 456_U HHSM << # HH8FKK ?rYresultc,URUupEURU UR5 [U[5(a/UR UR X!R 555 gURU5 g![a gf=fr) rrI isinstancer5rrgetErrorMessagecallbackKeyError)rUrrrrrs rV _checkTimeoutThreadedResolver._checkTimeout7s .'+';';N'K $L$$^4    &'**$$TZZ6L6L6N%OP%%f-   sB BBtimeoutcU(a [U5nOSn[5n[R"[ [ UR 5[ [UR 5R5[RU5n[ [UR 5RX0RX5nXF4URU'URUR X5nU$)a  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!rdeferToThreadPoolrr)rr, getThreadPoolsocket gethostbynamer- callLaterrraddBothr)rUrr timeoutDelayrrr_s rV getHostByNameThreadedResolver.getHostByNameGs w\?"\@5rAS\S.\6S/\74S0\8S8\8S\B4 S9jrCS:\BSS4S;jrDS:\BSS4S<jrES\)\F4S=jrGSNS>jrHS\\4S?jrISNS@jrJ\KR"5(aY\MceSrNSrOSrPSNSAjrQSB\6S/\74S0\8S1\8SS4SCjrRSNSDjrSSNSEjrTSNSFjrUS\M4SGjrVSH\6S/\74S0\8S1\8SS4SIjrWSJ\*SS4SKjrXSMrYU=rZ$SB\6S/\74S0\8S1\8SS4SLjrRSMrYU=rZ$)SriAa Default base class for Reactors. @ivar _stopped: A flag which is true between paired calls to C{reactor.run} and C{reactor.stop}. This should be replaced with an explicit state machine. @ivar _justStopped: A flag which is true between the time C{reactor.stop} is called and the time the shutdown system event is fired. This is used to determine whether that event should be fired after each iteration through the mainloop. This should be replaced with an explicit state machine. @ivar _started: A flag which is true from the time C{reactor.run} is called until the time C{reactor.run} returns. This is used to prevent calls to C{reactor.run} on a running reactor. This should be replaced with an explicit state machine. @ivar running: See L{IReactorCore.running} @ivar _registerAsIOThread: A flag controlling whether the reactor will register the thread it is running in as the I/O thread when it starts. If C{True}, registration will be done, otherwise it will not be. @ivar _exitSignal: See L{_ISupportsExitSignalCapturing._exitSignal} @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 @ivar _signals: An object which knows how to install and uninstall the reactor's signal-handling behavior. TFN_signalstwisted.internet.reactorrKc>[TU]5 /Ul0Ul/Ul/UlSUlSUlSUlSUl SUl [5Ul SUl URSSUR5 URSSUR 5 URSSUR"5 [$R&"5(aUR)5 UR+5 g)NrFrstartupshutdown)superrWthreadCallQueue_eventTriggers_pendingTimedCalls_newTimedCalls_cancellationsrunning_started _justStopped_startedBeforeset_internalReaderswakeraddSystemEventTrigger_reallyStartRunningcrash disconnectAllr7supportsThreads _initThreads installWaker)rU __class__s rVrWReactorBase.__init__os 24;=5713  !#+.% ""8Y8P8PQ ""8ZD ""8Z9K9KL  # # % %     rY_installSignalHandlersinstallSignalHandlerscDU(aUR5$[5$)z Get an appropriate signal handling object. @param installSignalHandlers: Indicate whether to even try to do any signal handling. If C{False} then the result will be a no-op implementation. )_signalsFactoryr;rUrBs rV_makeSignalHandlingReactorBase._makeSignalHandlings !'') )%''rYcX[URURUR5$)z{ Get a signal handling object that implements the basic behavior of stopping the reactor on SIGINT, SIGBREAK, and SIGTERM. )r<sigIntsigBreaksigTermr\s rVrDReactorBase._signalsFactorys& # KK MM LL  rYreaderc\URRU5 URU5 g)z Add a read descriptor which is part of the implementation of the reactor itself. The read descriptor will not be removed by L{IReactorFDSet.removeAll}. N)r6add addReaderrUrMs rV_addInternalReaderReactorBase._addInternalReaders$ !!&) vrYc\URRU5 URU5 g)zU Remove a read descriptor which is part of the implementation of the reactor itself. N)r6r removeReaderrQs rV_removeInternalReader!ReactorBase._removeInternalReaders& $$V, &!rYcURUS9 UR5 URR5 g!URR5 f=f)N)rB) startRunningmainLoopr& uninstallrEs rVrunReactorBase.runsC 0EF & MMO MM # # %DMM # # %s <AcBUR(ah[ UR5 UR5nUR=(a UnUR U5 SSS5 UR(aMh[ RS5 g!,(df  N7=f)NzMain loop terminated.)r2 _topHandlerrunUntilCurrentrr1 doIteration_loginfo)rUt2ts rVrZReactorBase.mainLoopsfmm$$&\\^LL'R  # mmm )* s AB BcZ[[R"UR5S-5e)Nz did not implement installWakerNotImplementedErrorr4qualr?r\s rVr>ReactorBase.installWaker%! LL (+L L  rYc\UR(aURR5 gg)z Wake up the event loop. N)r7wakeUpr\s rVrnReactorBase.wakeUps  :: JJ    rYrkcZ[[R"UR5S-5e)zF Do one iteration over the readers and writers which have been added. z did not implement doIterationrhrUrks rVraReactorBase.doIterations'" LL (+K K  rYcZ[[R"UR5S-5e)Nz did not implement addReaderrhrQs rVrPReactorBase.addReader%! LL (+I I  rYwritercZ[[R"UR5S-5e)Nz did not implement addWriterrhrUrvs rV addWriterReactorBase.addWriterrurYcZ[[R"UR5S-5e)Nz did not implement removeReaderrhrQs rVrUReactorBase.removeReaderrlrYcZ[[R"UR5S-5e)Nz did not implement removeWriterrhrxs rV removeWriterReactorBase.removeWriterrlrYcZ[[R"UR5S-5e)Nz did not implement removeAllrhr\s rV removeAllReactorBase.removeAllrurYcZ[[R"UR5S-5e)Nz did not implement getReadersrhr\s rV getReadersReactorBase.getReaders%! LL (+J J  rYcZ[[R"UR5S-5e)Nz did not implement getWritersrhr\s rV getWritersReactorBase.getWritersrrYrrcU(d[R"S5$[R"U5(a[R"U5$URR X5$)z0 Return a Deferred that will resolve a hostname.z0.0.0.0)rrr isIPAddressrr)rUrrs rVresolveReactorBase.resolvesK ==+ +    % %==& &}}**499rYc|UR(a[R"S5eSUlSUlSUlg)z4 See twisted.internet.interfaces.IReactorCore.stop. z&Can't stop reactor that isn't running.TN)_stoppedrReactorNotRunningr3r4r\s rVstopReactorBase.stops4 ==))*RS S  "rYcZSUlSUlURSSUR5 g)z See twisted.internet.interfaces.IReactorCore.crash. Reset reactor state tracking attributes and re-initialize certain state-transition helpers which were set up in C{__init__} but later destroyed (through use). Frr)N)r2r1r8r9r\s rVr:ReactorBase.crashs*   ""8Y8P8PQrYnumberframecp[RS5 URUR5 Xlg)z Handle a SIGINT interrupt. @param number: See handler specification in L{signal.signal} @param frame: See handler specification in L{signal.signal} zReceived SIGINT, shutting down.NrbrccallFromThreadr _exitSignalrUrrs rVrIReactorBase.sigInt's) 34 DII&!rYcp[RS5 URUR5 Xlg)z Handle a SIGBREAK interrupt. @param number: See handler specification in L{signal.signal} @param frame: See handler specification in L{signal.signal} z!Received SIGBREAK, shutting down.Nrrs rVrJReactorBase.sigBreak2s) 56 DII&!rYcp[RS5 URUR5 Xlg)z Handle a SIGTERM interrupt. @param number: See handler specification in L{signal.signal} @param frame: See handler specification in L{signal.signal} z Received SIGTERM, shutting down.Nrrs rVrKReactorBase.sigTerm=s) 45 DII&!rYcUR5nUH0n[X"R[[R 55 M2 g)z2Disconnect every reader, and writer in the system.N)r_callWithLoggerconnectionLostr5rCONNECTION_LOST)rU selectablesrMs rVr;ReactorBase.disconnectAllHs6nn& !F --wt7K7K/L "rYcFUR5 URU5 g)z7 See twisted.internet.interfaces.IReactorCore.iterate. N)r`rarqs rViterateReactorBase.iteratePs  rY eventTypecbURRU5nUbUR5 gg)z? See twisted.internet.interfaces.IReactorCore.fireSystemEvent. N)r-getr )rUrevents rVfireSystemEventReactorBase.fireSystemEventWs/##'' 2   OO  rYrr.rGrc[R"U5(d US35eX R;a[5URU'[ UURUR "X/UQ70UD645$)zE See twisted.internet.interfaces.IReactorCore.addSystemEventTrigger.  is not callable)builtinsrr-rr$r)rUrrrrGrs rVr8!ReactorBase.addSystemEventTrigger_s  **Ixj8H,II* // /-=-?D   *##I.99&*.4   rY triggerIDcHUup#URURU5 g)zH See twisted.internet.interfaces.IReactorCore.removeSystemEventTrigger. N)r-r)rUrrrs rVremoveSystemEventTrigger$ReactorBase.removeSystemEventTriggervs%&  I&44VregisterAsIOThreadrrEs rVrYReactorBase.startRunnings ==--/ /   --/ / !&;#001FG    # #  ) ) + Y'rYcjSUlUR(aURR5 gg)zu Method called to transition to the running state. This should happen in the I{during startup} event trigger phase. TN)r1rAr&installr\s rVr9ReactorBase._reallyStartRunnings+   & & MM ! ! # 'rYrHc US:d US35e[UR5U-UUUURURURS9nURR U5 U$)z9 See twisted.internet.interfaces.IReactorTime.callLater. rz* is not greater than or equal to 0 seconds)r8)rAr8_cancelCallLater_moveCallLaterSoonerr/r)rUrkrrGrH delayedCalls rVrReactorBase.callLaterss zOeW$NOOz! LLNU "     ! !  % %LL  "";/rYrcURnURU5nX#nUS:wa!US- S-nX%U::aOX%X#'UnUS:waM!XBU'g![a gf=f)Nrr9)r.indexr)rUrheapposeltparents rVr ReactorBase._moveCallLaterSooners|&& **[)C)C('a<3& L  (I   s:A A AAc.U=RS- slgNr9)r0)rUrs rVrReactorBase._cancelCallLaters q rYcURUR-Vs/sHnUR(aMUPM sn$s snf)zA See L{twisted.internet.interfaces.IReactorTime.getDelayedCalls} )r.r/rQ)rUxs rVgetDelayedCallsReactorBase.getDelayedCallssA --0C0CC C;; C   s>>cUR(dgURHQnUR(aU=RS-slM+UR5 [ UR U5 MS /Ulgr)r/rQr0rjrr.)rUcalls rV_insertNewDelayedCalls"ReactorBase._insertNewDelayedCallss^"" ''D~~##q(###%00$7 ( !rYcUR5 UR(dgURSRUR5- nSn[ S[ X!55$)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. Nri )rr.rEr8maxmin)rUrklongests rVrReactorBase.timeoutsX ##%&&''*//$,,.@1c')**rYcUR(aSn[UR5nURH)up4n[ U"U0UD6 SSS5 US- nX:XdM) O URSU2 UR(aUR5 UR 5 UR 5nUR (Ga5UR SRU::Ga[UR 5nUR(aU=RS-sl MmURS:a(UR5 [UR U5 MUR(a"[R!SUR4SjS9O["nU SUlUR&"UR(0UR*D6 SSS5 UR (a UR SRU::aGMURS:avUR[UR 5S- :aPSUl UR V s/sHoR(aMU PM sn Ul[-UR 5 UR.(aS UlUR1S 5 gg!,(df  GNg=f!,(df  GN=fs sn f) z Run all pending timed calls. rNr9rMz&while handling timed call {previous()}clSSRU5R5RSS5-S-$)Nz) C: from a DelayedCall created here: C:r z C:)rrstripreplace)rDs rV-ReactorBase.runUntilCurrent..Bs; '''*113;;D'JK rY)previous2Fr*)r,len_threadCallHandlerrnrr8r.rErrQr0rSrjrrDrbfailuresHandled%_DEFAULT_DELAYED_CALL_LOGGING_HANDLERrRrFrGrHrr3r) rUcounttotalfarHrr logHandlerrs rVr`ReactorBase.runUntilCurrentsD   E,,-E 00b'qKBK( > 1 $$VeV,##  ##%lln%%%4+B+B1+E+J+Jc+Q4223D~~##q(#  3&##%00$7<<$$<,0LL% ;    499007%%4+B+B1+E+J+Jc+Q@   " $##c$*A*A&Ba&GG"#D 22'2a++2'D # D++ ,    %D    , m('P's$ J*.J<KK* J9 < K cxUR[[[U5UR55 SUlg)NT)r _GAIResolverrr,r usingThreadsr\s rVr=ReactorBase._initThreadsks1  $ $T/48$:L:LM !%D rYrc[U5(d US35eURRXU45 UR5 g)zH See L{twisted.internet.interfaces.IReactorFromThreads.callFromThread}. rN)rr,rrnrUrrGrs rVrReactorBase.callFromThreadtsCA;; 61#%5 6 6;  ' '&(9 : KKMrYc[SSS5UlURURR5UlUR SSUR 5Ulg)z7 Create the threadpool accessible with callFromThread. r r'rr*N)r? threadpoolrstart_threadpoolStartupIDr8_stopThreadPoolthreadpoolShutdownIDr\s rV_initThreadPoolReactorBase._initThreadPoolsR)B0JKDO(,(<(UR5RUS9 g)zK See L{twisted.internet.interfaces.IReactorThreads.suggestThreadPoolSize}. ) maxthreadsN)radjustPoolsize)rUrs rVsuggestThreadPoolSize!ReactorBase.suggestThreadPoolSizes    / /4 / @rYcr[U5(d US35eURRXU45 g)Nr)rr,rrs rVrrs8A;; 61#%5 6 6;  ' '&(9 :rY)r0r-rrAr6r3r/r.r&r2r4rrr1r,rrrr7r)Trr)rM)[r}rr|rrrr installedrrr;r&r:rrWrArrFrDr.rRrVr\rZ_lockr>rnrrrarPr0ryrUr~rrrrrrrrr!rrr:r rIrJrKr;rrr r rr$r8rrrYr9 staticmethodrr8rArrrr%rrrr`r7r<r?rrrr=rrrrrrrr __classcell__)r?s@rVrrAsS:HILK 67Hn7)H8$)D( ( (. (    T"O""&&&+ E   % T   D  0 T  ? t  #3   4o7G&G HI  D1  D!12 3A : :"*3- : # :# R "S "))< " " "s "8I+> "$ " "c "(9*= " " U T    38$        .=.=T=  c* 39 EK  . ! ($($(> $">*G&.sCx&8AGOU & (!K!D! ,!7  !+%+8C-L!!%%% ## % c3h' 06 BH     & #& #: # J%c3h/ J8> JJP J  J Ac Ad A A ;c3h' ;06 ;BH ;  ; ;rYrc\rSrSrSrSrSrS\S\S\ SS4S jr SS jr \ SS j5r SS jrSS jrSSjrS\S\\4SjrS\SS4SjrS\SS4SjrS\4SjrS\4SjrSrg) BaseConnectoriza Basic implementation of L{IConnector}. State can be: "connecting", "connected", "disconnected" NrfactoryrrrKc6SUlX0lXlX lg)N disconnected)rrrr)rUrrrs rVrWBaseConnector.__init__s$    rYcURS:XaUR5 gURS:Xa*URceURR5 gg)z!Disconnect whatever our state is. connecting connectedN)rstopConnecting transportloseConnectionr\s rV disconnectBaseConnector.disconnectsK :: %    ! ZZ; &>>- -- NN ) ) +'rYcgrrr\s rV_makeTransportBaseConnector._makeTransports rYcURS:wa [S5eSUlUR(d!URR 5 SUlUR 5UlURbSURRURUR R[R"55Ul URRU5 g)z"Start connection to remote server.r!zcan't connect in this stater$r9N)r RuntimeErrorfactoryStartedrdoStartr,r'rrrfailIfNotConnectedr TimeoutError timeoutIDstartedConnectingr\s rVconnectBaseConnector.connects :: '<= =! "" LL ""#D +/+>+>+@ << #!\\33 dnn??ASASAUDN &&t,rYcURS:wa[R"S5eURceSUlURR [R "55 U?g)zStop attempting to connect.r$zwe're not trying to connectNr!)rrNotConnectingErrorr'r2 UserErrorr\s rVr&BaseConnector.stopConnectingsU :: %**+HI I~~)))#  ))%//*;< NrYczURbURR5 U?gg![a Nf=fr)r4rIrr\s rV cancelTimeoutBaseConnector.cancelTimeoutsA >> % %%' &  s - ::addrcfSUlUR5 URRU5$)Nr%)rr=r buildProtocol)rUr?s rVrABaseConnector.buildProtocol s*   ||))$//rYreasoncUR5 SUlSUlURR X5 URS:Xa"URR 5 SUlggNr!r)r=r'rrclientConnectionFaileddoStopr0rUrCs rVconnectionFailedBaseConnector.connectionFailedsW #  ++D9 :: ' LL   !"#D  (rYcSUlURRX5 URS:Xa"URR5 SUlggrE)rrclientConnectionLostrGr0rHs rVrBaseConnector.connectionLostsD#  ))$7 :: ' LL   !"#D  (rYcZ[[R"UR5S-5e)Nz! did not implement getDestinationrhr\s rVgetDestinationBaseConnector.getDestination"s%! LL (+Q Q  rYcSR[R"UR5[ U5UR UR 55$)Nz<{} instance at 0x{:x} {} {}>)formatr4rjr?rrrOr\s rVrBaseConnector.__repr__'s?.55 LL ( tH JJ    !   rY)rr0rrrr4r'r)rKr=)r}rr|rrr4r0r2rrrWr)rr,r6r&r=r#rr'rAr5rIrrOrrrrrYrVrrs IN$/4?J ,  - 0(0x /B0 $w$4$$W$$   # rYrc\rSrSr%SrSr\R\S'Sr \R\S'S\R 4Sjr S\ \ 4SjrS rg) BasePorti0zaBasic implementation of a ListeningPort. Note: This does not actually implement IListeningPort. N addressFamily socketTyperKc[R"URUR5nURS5 [R "UR 55 U$)NF)rrVrW setblockingr_setCloseOnExecfileno)rUss rVcreateInternetSocketBasePort.createInternetSocket9sA MM$,,doo > e ahhj)rYcZ[S[R"UR5-5e)zRaises a RuntimeErrorzdoWrite called on a %s)r/r4rjr?r\s rVdoWriteBasePort.doWrite?s 3gll4>>6RRSSrYr)r}rr|rrrVr AddressFamilyrrW SocketKindr]rr5r`rrrYrVrUrU0sL +/M6''.$(J!!(fmm T'*TrYrU__all__)qrrrrabcrrheapqrrr tracebackrtypesr typingr r r r rrrrrrrrzope.interfacerrtwisted.internetrrrrrrtwisted.internet._resolverrrrrr rtwisted.internet.deferr!r"twisted.internet.interfacesr#r$r%r&r'r(r)r*r+r,r-r.r/r0r1twisted.internet.protocolr2twisted.loggerr3twisted.pythonr4twisted.python.failurer5twisted.python.logr6rtwisted.python.runtimer7r8rr&r:r;r<twisted.internet.tcpr=r>r<twisted.python.threadpoolr?rbfailureHandlerr_rrrArrrrr_ThreePhaseEventTriggerrrrr$ _ThreadCallrrrFileDescriptorrUrdrrrYrVr{s   #,,"    8II :"4!"*@FQQ+& 4J x!!"AB (()DE))*VW \@@@F _GGGT _ * * *#+38"4#U63;%7c6k9JJ!(# #.fck0BDfDU UV! G.G.T *,EF."."G."b)56S1S+TUHS#X&fck(:Df