o b@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!dd d Z"dd dZ#dddZ$dddZ%dddZ&dddZ'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).NcKdSN_r"r"D/usr/lib/python3/dist-packages/twisted/application/runner/_runner.pyCzRunner.cKr r!r"r#r"r"r%r&Er'returnNcCsv|j}|z#||||WdWdS1s#wYWdSty:ttjdYdSw)z# Run this command. NzAlready running.) _pidFilekillIfRequested startLogging startReactor reactorExitedrrr EX_CONFIG)selfpidFiler"r"r%runHs &  z Runner.runcCs|j}|jrP|turttjddSz|}Wnty(ttjdYdSt y7ttj dYdSw| |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/r0r2r"r"r%r*[s(        zRunner.killIfRequestedcCs<|j}|j}||}t|jd}t||g}t|gdS)z= Start the L{twisted.logger} logging system. )defaultLogLevelN)_logFile_fileLogObserverFactoryr_defaultLogLevelrrbeginLoggingTo)r/logFilefileLogObserverFactoryfileLogObserverlogLevelPredicatefilteringObserverr"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)_reactorcallWhenRunning whenRunningr9r:r1r/r"r"r%r,s zRunner.startReactorcC|jdi|jdS)z Call C{self._whenRunning} with C{self._whenRunningArguments}. @note: This method is called after the reactor starts running. Nr") _whenRunning_whenRunningArgumentsrIr"r"r%rHzRunner.whenRunningcCrJ)z Call C{self._reactorExited} with C{self._reactorExitedArguments}. @note: This method is called after the reactor exits. Nr")_reactorExited_reactorExitedArgumentsrIr"r"r%r-rMzRunner.reactorExited)r(N)(__name__ __module__ __qualname____doc__rr9r r rFrrr)boolr3r rr:r?rrr=rrrr>rKrstrrr dictrLrNrOr1r*r+r,rHr-r"r"r"r%rs*       !  rN)%rSosrsignalrsysrtypingrrrrattrr r r constantlyr twisted.internet.interfacesr twisted.loggerrrrrrrr_exitrr_pidfilerrrrrr"r"r"r%s     $