U  W[@sdZddlmZddlmZddlmZddlmZm Z m Z ddl m Z m Z mZmZmZmZddlmZmZdd lmZmZmZe d d Gd d d eZdS)z Twisted application runner. )stderr)SIGTERM)kill)attribattrsFactory)globalLogBeginnertextFileLogObserverFilteringLogObserverLogLevelFilterPredicateLogLevelLogger)exit ExitStatus) nonePIDFileAlreadyRunningErrorInvalidPIDFileErrorT)frozenc@seZdZdZeZeZeedZ eddZ ee j dZ eedZeedZedddZeeedZedddZeeedZddZd d Zd d Zd dZddZddZdS)Runnera Twisted application runner. @cvar _log: The logger attached to this class. @type _log: L{Logger} @ivar _reactor: The reactor to start and run the application in. @type _reactor: L{IReactorCore} @ivar _pidFile: The file to store the running process ID in. @type _pidFile: L{IPIDFile} @ivar _kill: Whether this runner should kill an existing running instance of the application. @type _kill: L{bool} @ivar _defaultLogLevel: The default log level to start the logging system with. @type _defaultLogLevel: L{constantly.NamedConstant} from L{LogLevel} @ivar _logFile: A file stream to write logging output to. @type _logFile: writable file-like object @ivar _fileLogObserverFactory: A factory for the file log observer to use when starting the logging system. @type _pidFile: callable that takes a single writable file-like object argument and returns a L{twisted.logger.FileLogObserver} @ivar _whenRunning: Hook to call after the reactor is running; this is where the application code that relies on the reactor gets called. @type _whenRunning: callable that takes the keyword arguments specified by C{whenRunningArguments} @ivar _whenRunningArguments: Keyword arguments to pass to C{whenRunning} when it is called. @type _whenRunningArguments: L{dict} @ivar _reactorExited: Hook to call after the reactor exits. @type _reactorExited: callable that takes the keyword arguments specified by C{reactorExitedArguments} @ivar _reactorExitedArguments: Keyword arguments to pass to C{reactorExited} when it is called. @type _reactorExitedArguments: L{dict} )defaultFcKsdSN_rrD/usr/lib/python3/dist-packages/twisted/application/runner/_runner.pySzRunner.cKsdSrrrrrrrUrc Csb|j}|z,||||W5QRXWn"tk r\ttjdYdSXdS)z# Run this command. zAlready running.N) _pidFilekillIfRequested startLogging startReactor reactorExitedrrr EX_CONFIG)selfpidFilerrrrunYs 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_USAGEreadEnvironmentErrorEX_IOERRr EX_DATAERRr _loginforrEX_OK)r$r%r'rrrrls$      zRunner.killIfRequestedcCs<|j}|j}||}t|jd}t||g}t|gdS)z= Start the L{twisted.logger} logging system. )ZdefaultLogLevelN)_logFile_fileLogObserverFactoryr _defaultLogLevelr rZbeginLoggingTo)r$ZlogFileZfileLogObserverFactoryZfileLogObserverZlogLevelPredicateZfilteringObserverrrrr szRunner.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 whenRunningr.r/r&r$rrrr!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_whenRunningArgumentsr6rrrr5szRunner.whenRunningcCs|jf|jdS)z Call C{self._reactorExited} with C{self._reactorExitedArguments}. @note: This method is called after the reactor exits. N)_reactorExited_reactorExitedArgumentsr6rrrr"szRunner.reactorExitedN)__name__ __module__ __qualname____doc__r r.rr4rrr(r r/r3rr1r r2r7rdictr8r9r:r&rr r!r5r"rrrrrs$/       rN)r>sysrsignalrosrattrrrrZtwisted.loggerrr r r r r _exitrrZ_pidfilerrrobjectrrrrrs