U 2ܟj@sdZddlmZddlmZddlmZddlmZm Z m Z m Z ddl m Z mZmZddlmZddlmZdd lmZmZmZmZmZmZmZd d lmZmZd d lm Z m!Z!m"Z"m#Z#ed dGdddZ$dS)z Twisted application runner. )kill)SIGTERM)stderr)AnyCallableMappingTextIO)Factoryattribattrs) NamedConstant) IReactorCore)FileLogObserverFilteringLogObserverLoggerLogLevelLogLevelFilterPredicateglobalLogBeginnertextFileLogObserver) ExitStatusexit)AlreadyRunningErrorInvalidPIDFileErrorIPIDFile nonePIDFileT)frozenc@seZdZdZeZeedZee e dZ ee ddZ eeejdZeeedZeeegefedZeeddddZeeeefeedZeeddddZ eeeefeedZ!d d d d Z"d d d dZ#d d ddZ$d d ddZ%d d ddZ&d d ddZ'd S)Runnera Twisted application runner. @cvar _log: The logger attached to this class. @ivar _reactor: The reactor to start and run the application in. @ivar _pidFile: The file to store the running process ID in. @ivar _kill: Whether this runner should kill an existing running instance of the application. @ivar _defaultLogLevel: The default log level to start the logging system with. @ivar _logFile: A file stream to write logging output to. @ivar _fileLogObserverFactory: A factory for the file log observer to use when starting the logging system. @ivar _whenRunning: Hook to call after the reactor is running; this is where the application code that relies on the reactor gets called. @ivar _whenRunningArguments: Keyword arguments to pass to C{whenRunning} when it is called. @ivar _reactorExited: Hook to call after the reactor exits. @ivar _reactorExitedArguments: Keyword arguments to pass to C{reactorExited} when it is called. )type)rdefaultF).NcKsdSN_r!r!F/tmp/pip-unpacked-wheel-4b529toj/twisted/application/runner/_runner.pyCzRunner.cKsdSr r!r"r!r!r$r%Er&N)returnc Csb|j}|z,||||W5QRXWn"tk r\ttjdYdSXdS)z# Run this command. zAlready running.N) _pidFilekillIfRequested startLogging startReactor reactorExitedrrr EX_CONFIG)selfpidFiler!r!r$runHs z Runner.runcCs|j}|jr|tkr$ttjddSz |}WnBtk rRttjdYdSt k rrttj dYdSX| |j j d|dt|tttjdSdS)zj If C{self._kill} is true, attempt to kill a running instance of the application. zNo PID file specified.NzUnable to read PID file.zInvalid PID file.zTerminating process: {pid})pid)r(_killrrrEX_USAGEreadOSErrorEX_IOERRr EX_DATAERRr*_loginforrEX_OK)r.r/r1r!r!r$r)[s$      zRunner.killIfRequestedcCs<|j}|j}||}t|jd}t||g}t|gdS)z= Start the L{twisted.logger} logging system. )ZdefaultLogLevelN)_logFile_fileLogObserverFactoryr_defaultLogLevelrrZbeginLoggingTo)r.ZlogFileZfileLogObserverFactoryZfileLogObserverZlogLevelPredicateZfilteringObserverr!r!r$r*|s zRunner.startLoggingcCs(|j|j|jd|jdS)z Register C{self._whenRunning} with the reactor so that it is called once the reactor is running, then start the reactor. zStarting reactor...N)_reactorZcallWhenRunning whenRunningr8r9r0r.r!r!r$r+s zRunner.startReactorcCs|jf|jdS)z Call C{self._whenRunning} with C{self._whenRunningArguments}. @note: This method is called after the reactor starts running. N) _whenRunning_whenRunningArgumentsr@r!r!r$r?szRunner.whenRunningcCs|jf|jdS)z Call C{self._reactorExited} with C{self._reactorExitedArguments}. @note: This method is called after the reactor exits. N)_reactorExited_reactorExitedArgumentsr@r!r!r$r,szRunner.reactorExited)(__name__ __module__ __qualname____doc__rr8r r r>rrr(boolr2r rr9r=rrr;rrrr<rArstrrr dictrBrCrDr0r)r*r+r?r,r!r!r!r$rs*     ! rN)%rHosrsignalrsysrtypingrrrrattrr r r Z constantlyr Ztwisted.internet.interfacesr Ztwisted.loggerrrrrrrr_exitrrZ_pidfilerrrrrr!r!r!r$s     $