Vh2dZddlmZddlmZddlmZddlmZddl m Z ddl m Z m Z mZGd d ejZGd d eZGd deZdZdZGddeZGddeZGddeZGddeZGddeZGddeZGddeZGdd eZGd!d"eZGd#d$eZGd%d&eZGd'd(ejZ Gd)d*ejZ!gd+Z"y,)-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 backoffPolicyc(eZdZUgZeeed<dZy)_VolatileDataServicevolatilecvtjj|}|jD] }||vs||= |SN)rService __getstate__r)selfdattrs L/home/dcms/DCMS/lib/python3.12/site-packages/twisted/application/internet.pyrz!_VolatileDataService.__getstate__5s> OO ( ( .MM DqydG N)__name__ __module__ __qualname__rrstr__annotations__rrrr r 2sHd3irr cLeZdZUdZdgZdZeed<dZdZ dZ dZ dZ d Z d Zy) _AbstractServera @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}. _portmethodNcT||_d|vr|jd|_||_yNreactorargspopr%kwargsrr'r)s r__init__z_AbstractServer.__init__T(  !::i0DL rcltjj||j|_yr)rrprivilegedStartService_getPortr rs rr.z&_AbstractServer.privilegedStartServiceZs!..t4]]_ rctjj||j|j |_yyr)rr startServicer r/r0s rr2z_AbstractServer.startService^s0$$T* :: DJ rctjj||j|jj }|`|Syr)rr stopServicer stopListening)rrs rr4z_AbstractServer.stopServicecsA##D) :: ! ((*A H "rctt|jdj|j|j i|j S)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)r0s rr/z_AbstractServer._getPortlsP w  -      99 %  % %r)rrr__doc__rr"rrr%r r+r.r2r4r/rrrrr=s= yHFCG E %)  %rrcFeZdZUdZdgZdZeed<dZdZ dZ dZ dZ d Z y) _AbstractClienta& @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"NcT||_d|vr|jd|_||_yr$r&r*s rr+z_AbstractClient.__init__r,rcltjj||j|_yr)rrr2_getConnectionr<r0s rr2z_AbstractClient.startServices%$$T*..0rctjj||j|jj |`yyr)rrr4r< disconnectr0s rr4z_AbstractClient.stopServices=##D)    '    ' ' )  (rctt|jd|j|ji|j S)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)r7r r%r"r'r)r0s rr?z_AbstractClient._getConnectionsCSw*4<<8GDKK=:QR YY ++  r)rrrr9rr"rrr%r<r+r2r4r?rrrr;r;|s8 HFCGK 1!  rr;ztConnect 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. c4eZdZej dZdZy) TCPServerTCPtranNrrr _serverDocr8r9r"rrrrErEU+G FrrEc4eZdZej dZdZy) TCPClientrFrGNrrr _clientDocr8r9r"rrrrMrMrKrrMc4eZdZej dZdZy) UNIXServerUNIXrGNrIrrrrQrQV,G FrrQc4eZdZej dZdZy) UNIXClientrRrGNrNrrrrUrUrSrrUc4eZdZej dZdZy) SSLServerSSLrGNrIrrrrWrWrKrrWc4eZdZej dZdZy) SSLClientrXrGNrNrrrrZrZrKrrZc4eZdZej dZdZy) UDPServerUDPrGNrIrrrr\r\rKrr\c4eZdZej dZdZy)UNIXDatagramServer UNIXDatagramrGNrIrrrr_r_^4G Frr_c4eZdZej dZdZy)UNIXDatagramClientr`rGNrNrrrrcrcrarrcc4eZdZej dZdZy)MulticastServer MulticastrGNrIrrrreres[1G Frrec0eZdZdZddgZdZdZdZdZy) TimerServicea 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 _loopFinishedc4||_|||f|_d|_y)a+ @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)rrlcallabler'r)s rr+zTimerService.__init__s  tV,  rctjj||j\}}}t j |g|i||_t|j|j _|j j|jd|_ |jj|jy)NT)now)rrr2rmr LoopingCallrir rnstartrlrj addErrback_failed)rror'r)s rr2zTimerService.startServices$$T*!%$ %%h@@@ .tzz: !ZZ--diiT-B %%dll3rcPd|j_tj|yNF)rirunningrerr)rwhys rruzTimerService._faileds#   rcjjrjjjj fdjS)z Stop the service. @rtype: L{Deferred} @return: a L{Deferred} which is fired when the currently running call (if any) is finished. cBtjjSr)rrr4)_rs rz*TimerService.stopService..0s1L1LT1Rr)rirxstoprj addCallbackr0s`rr4zTimerService.stopService&sA ::   JJOO  &&'RS!!!rN) rrrr9rr+r2rur4rrrrhrhs'")H  4 "rrhc(eZdZdZdZdZdZdZy)CooperatorServicezb Simple L{service.IService} which starts and stops a L{twisted.internet.task.Cooperator}. c:tjd|_y)NF)started)r Cooperatorcoopr0s rr+zCooperatorService.__init__9sOOE2 rc8|jj|Sr)r coiterate)riterators rrzCooperatorService.coiterate<syy""8,,rc8|jjyr)rrsr0s rr2zCooperatorService.startService?s rc8|jjyr)rrr0s rr4zCooperatorService.stopServiceBs rN)rrrr9r+rr2r4rrrrr4s3-rrc,eZdZdZdZdZdZdZdZy)StreamServerEndpointServiceaP 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.||_||_d|_yr)endpointfactory_waitingForPort)rrrs rr+z$StreamServerEndpointService.__init__as   #rctjjjj j _gfd}j j|rdjd_ y)z2 Start listening on the endpoint. cjrj|y|jtst j |yyr)_raiseSynchronouslyappendcheckrrry)ry raisedNowrs rhandleItzDStreamServerEndpointService.privilegedStartService..handleItns6''  %YY~. /rrFN) rrr.rlistenrrrtraiseExceptionr)rrrs` @rr.z2StreamServerEndpointService.privilegedStartServicefsm ..t4#}}33DLLA   ''1  aL ' ' )#( rc|tjj||j|j yy)zu Start listening on the endpoint, unless L{privilegedStartService} got around to it already. N)rrr2rr.r0s rr2z(StreamServerEndpointService.startServiceys3 $$T*    '  ' ' ) (rcjjd}jj|}fd}|j||S)a 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(||jSyr)r5)ports rstopItz7StreamServerEndpointService.stopService..stopIts))++ rcd_|Srw)rx) passthroughrs rrz5StreamServerEndpointService.stopService..stops DL r)rcancelraddBoth)rrrrs` rr4z'StreamServerEndpointService.stopServicesK ##% ,  , ,V 4  $rN) rrrr9rr+r.r2r4rrrrrFs#0 $ )&*rr)rhrrerr\r rErMrQrUrWrZr_rcr r N)#r9typingrtwisted.applicationrtwisted.internetrtwisted.internet.deferrtwisted.pythonr_client_servicer r r rr rr;rOrJrErMrQrUrWrZr\r_rcrerhrr__all__rrrrs !H'!1NN7??<%*<%~0 *0 f           o A"'A"H$Q'//Qh r