h2SrSSKJr SSKJr SSKJr SSKJr SSK J r SSK J r J r Jr "S S \R5r"S S \5r"S S\5rSrSr"SS\5r"SS\5r"SS\5r"SS\5r"SS\5r"SS\5r"SS\5r"SS \5r"S!S"\5r"S#S$\5r"S%S&\5r"S'S(\R5r "S)S*\R5r!/S+Qr"g,)-a Reactor-based Services Here are services to run clients, servers and periodic services using the reactor. If you want to run a server service, L{StreamServerEndpointService} defines a service that can wrap an arbitrary L{IStreamServerEndpoint } as an L{IService}. See also L{twisted.application.strports.service} for constructing one of these directly from a descriptive string. Additionally, this module (dynamically) defines various Service subclasses that let you represent clients and servers in a Service hierarchy. Endpoints APIs should be preferred for stream server services, but since those APIs do not yet exist for clients or datagram services, many of these are still useful. They are as follows:: TCPServer, TCPClient, UNIXServer, UNIXClient, SSLServer, SSLClient, UDPServer, UNIXDatagramServer, UNIXDatagramClient, MulticastServer These classes take arbitrary arguments in their constructors and pass them straight on to their respective reactor.listenXXX or reactor.connectXXX calls. For example, the following service starts a web server on port 8080: C{TCPServer(8080, server.Site(r))}. See the documentation for the reactor.listen/connect* methods for more information. )List)service)task)CancelledError)log) ClientService_maybeGlobalReactor backoffPolicyc0\rSrSr%/r\\\S'SrSr g)_VolatileDataService2volatilec|[RRU5nURH nX!;dM X M U$N)rService __getstate__r)selfdattrs c/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/application/internet.pyr!_VolatileDataService.__getstate__5s5 OO ( ( .MMDyG"N) __name__ __module__ __qualname____firstlineno__rrstr__annotations__r__static_attributes__rrrr r 2sHd3irr cT\rSrSr%SrS/rSr\\S'Sr Sr Sr Sr S r S rS rS rg) _AbstractServer=a @cvar volatile: list of attribute to remove from pickling. @type volatile: C{list} @ivar method: the type of method to call on the reactor, one of B{TCP}, B{UDP}, B{SSL} or B{UNIX}. @type method: C{str} @ivar reactor: the current running reactor. @type reactor: a provider of C{IReactorTCP}, C{IReactorUDP}, C{IReactorSSL} or C{IReactorUnix}. @ivar _port: instance of port set when the service is started. @type _port: a provider of L{twisted.internet.interfaces.IListeningPort}. _portmethodNcTXlSU;aURS5UlX lgNreactorargspopr*kwargsrr,r.s r__init___AbstractServer.__init__T$  !::i0DL rcl[RRU5 UR5Ulgr)rrprivilegedStartService_getPortr%rs rr4&_AbstractServer.privilegedStartServiceZs!..t4]]_ rc[RRU5 URcUR 5Ulggr)rr startServicer%r5r6s rr9_AbstractServer.startService^s0$$T* :: DJ rc[RRU5 URbURR 5nU?U$gr)rr stopServicer% stopListening)rrs rr<_AbstractServer.stopServicecsA##D) :: ! ((*A H "rc[[UR5SRUR55"UR 0UR D6$)z Wrapper around the appropriate listen method of the reactor. @return: the port object returned by the listen method. @rtype: an object providing L{twisted.internet.interfaces.IListeningPort}. zlisten{})getattrr r*formatr'r,r.r6s rr5_AbstractServer._getPortlsN  -      99 %  % %r)r%r,r.r*)rrrr__doc__rr'rr r*r%r0r4r9r<r5r!rrrr#r#=s= yHFCG E %)  %rr#cN\rSrSr%SrS/rSr\\S'Sr Sr Sr Sr S r S rS rg) _AbstractClient|a @cvar volatile: list of attribute to remove from pickling. @type volatile: C{list} @ivar method: the type of method to call on the reactor, one of B{TCP}, B{UDP}, B{SSL} or B{UNIX}. @type method: C{str} @ivar reactor: the current running reactor. @type reactor: a provider of C{IReactorTCP}, C{IReactorUDP}, C{IReactorSSL} or C{IReactorUnix}. @ivar _connection: instance of connection set when the service is started. @type _connection: a provider of L{twisted.internet.interfaces.IConnector}. _connectionr&r'NcTXlSU;aURS5UlX lgr)r+r/s rr0_AbstractClient.__init__r2rcl[RRU5 UR5Ulgr)rrr9_getConnectionrGr6s rr9_AbstractClient.startServices%$$T*..0rc[RRU5 URbURR 5 U?ggr)rrr<rG disconnectr6s rr<_AbstractClient.stopServices=##D)    '    ' ' )  (rc[[UR5SUR35"UR0UR D6$)z Wrapper around the appropriate connect method of the reactor. @return: the port object returned by the connect method. @rtype: an object providing L{twisted.internet.interfaces.IConnector}. connect)r@r r*r'r,r.r6s rrK_AbstractClient._getConnections@*4<<8GDKK=:QR YY ++  r)rGr,r.r*)rrrrrCrr'rr r*rGr0r9r<rKr!rrrrErE|s8 HFCGK 1!  rrEztConnect to {tran} Call reactor.connect{tran} when the service starts, with the arguments given to the constructor. zServe {tran} clients Call reactor.listen{tran} when the service starts, with the arguments given to the constructor. When the service stops, stop listening. See twisted.internet.interfaces for documentation on arguments to the reactor method. c6\rSrSr\R SS9rSrSrg) TCPServerTCPtranrN rrrr _serverDocrArCr'r!rrrrTrTU+G FrrTc6\rSrSr\R SS9rSrSrg) TCPClientrVrWrN rrrr _clientDocrArCr'r!rrrr]r]r[rr]c6\rSrSr\R SS9rSrSrg) UNIXServerUNIXrWrNrYrrrrbrbV,G Frrbc6\rSrSr\R SS9rSrSrg) UNIXClientrdrWrNr_rrrrgrgrerrgc6\rSrSr\R SS9rSrSrg) SSLServerSSLrWrNrYrrrrjrjr[rrjc6\rSrSr\R SS9rSrSrg) SSLClientrlrWrNr_rrrrnrnr[rrnc6\rSrSr\R SS9rSrSrg) UDPServerUDPrWrNrYrrrrqrqr[rrqc6\rSrSr\R SS9rSrSrg)UNIXDatagramServer UNIXDatagramrWrNrYrrrruru^4G Frruc6\rSrSr\R SS9rSrSrg)UNIXDatagramClientrwrWrNr_rrrrzrzrxrrzc6\rSrSr\R SS9rSrSrg)MulticastServer MulticastrWrNrYrrrr}r}s[1G Frr}c8\rSrSrSrSS/rSrSrSrSr S r g ) TimerServiceaZ Service to periodically call a function Every C{step} seconds call the given function with the given arguments. The service starts the calls when it starts, and cancels them when it stops. @ivar clock: Source of time. This defaults to L{None} which is causes L{twisted.internet.reactor} to be used. Feel free to set this to something else, but it probably ought to be set *before* calling L{startService}. @type clock: L{IReactorTime} @ivar call: Function and arguments to call periodically. @type call: L{tuple} of C{(callable, args, kwargs)} _loop _loopFinishedc0XlX#U4UlSUlg)z @param step: The number of seconds between calls. @type step: L{float} @param callable: Function to call @type callable: L{callable} @param args: Positional arguments to pass to function @param kwargs: Keyword arguments to pass to function N)stepcallclock)rrcallabler,r.s rr0TimerService.__init__s V,  rc[RRU5 URupn[R "U/UQ70UD6Ul[UR5UR lUR RURSS9Ul URRUR5 g)NT)now)rrr9rr LoopingCallrr rstartrr addErrback_failed)rrr,r.s rr9TimerService.startServices$$T*!% %%h@@@ .tzz: !ZZ--diiT-B %%dll3rcRSURl[R"U5 gNF)rrunningrerr)rwhys rrTimerService._faileds#   rc^TRR(aTRR5 TRR U4Sj5 TR$)z Stop the service. @rtype: L{Deferred} @return: a L{Deferred} which is fired when the currently running call (if any) is finished. cB>[RRT5$r)rrr<)_rs r*TimerService.stopService..0s1L1LT1Rr)rrstopr addCallbackr6s`rr<TimerService.stopService&sA ::   JJOO  &&'RS!!!r)rrrrrN) rrrrrCrr0r9rr<r!rrrrrs'")H  4 "rrc0\rSrSrSrSrSrSrSrSr g) CooperatorServicei4zZ Simple L{service.IService} which starts and stops a L{twisted.internet.task.Cooperator}. c6[R"SS9Ulg)NF)started)r Cooperatorcoopr6s rr0CooperatorService.__init__9sOOE2 rc8URRU5$r)r coiterate)riterators rrCooperatorService.coiterate<syy""8,,rc8URR5 gr)rrr6s rr9CooperatorService.startService?s rc8URR5 gr)rrr6s rr<CooperatorService.stopServiceBs r)rN) rrrrrCr0rr9r<r!rrrrr4s3-rrc4\rSrSrSrSrSrSrSrSr Sr g ) StreamServerEndpointServiceiFa A L{StreamServerEndpointService} is an L{IService} which runs a server on a listening port described by an L{IStreamServerEndpoint }. @ivar factory: A server factory which will be used to listen on the endpoint. @ivar endpoint: An L{IStreamServerEndpoint } provider which will be used to listen when the service starts. @ivar _waitingForPort: a Deferred, if C{listen} has yet been invoked on the endpoint, otherwise None. @ivar _raiseSynchronously: Defines error-handling behavior for the case where C{listen(...)} raises an exception before C{startService} or C{privilegedStartService} have completed. @type _raiseSynchronously: C{bool} @since: 10.2 Fc*XlX lSUlgr)endpointfactory_waitingForPort)rrrs rr0$StreamServerEndpointService.__init__as  #rc$^^[RRT5 TRR TR 5Tl/mUU4SjnTR RU5 T(aTSR5 STl g)z" Start listening on the endpoint. c>TR(aTRU5 gUR[5(d[R "U5 ggr)_raiseSynchronouslyappendcheckrrr)r raisedNowrs rhandleItDStreamServerEndpointService.privilegedStartService..handleItns9''  %YY~.. /rrFN) rrr4rlistenrrrraiseExceptionr)rrrs` @rr42StreamServerEndpointService.privilegedStartServicefsm ..t4#}}33DLLA   ''1  aL ' ' )#( rc~[RRU5 URcUR 5 gg)z] Start listening on the endpoint, unless L{privilegedStartService} got around to it already. N)rrr9rr4r6s rr9(StreamServerEndpointService.startServiceys3 $$T*    '  ' ' ) (rc^TRR5 SnTRRU5nU4SjnURU5 U$)z Stop listening on the port if it is already listening, otherwise, cancel the attempt to listen. @return: a L{Deferred} which fires with L{None} when the port has stopped listening. c*UbUR5$gr)r=)ports rstopIt7StreamServerEndpointService.stopService..stopIts))++ rc>STlU$r)r) passthroughrs rr5StreamServerEndpointService.stopService..stops DL r)rcancelraddBoth)rrrrs` rr<'StreamServerEndpointService.stopServicesK ##% ,  , ,V 4  $r)rrrrrN) rrrrrCrr0r4r9r<r!rrrrrFs#0 $ )&*rr)rrr}rrqr rTr]rbrgrjrnrurzr r N)#rCtypingrtwisted.applicationrtwisted.internetrtwisted.internet.deferrtwisted.pythonr_client_servicer r r rr r#rEr`rZrTr]rbrgrjrnrqrurzr}rrr__all__rrrrs !H'!1NN7??<%*<%~0 *0 f           o A"'A"H$Q'//Qh r