File: //usr/lib/python3/dist-packages/twisted/application/runner/__pycache__/_runner.cpython-310.pyc
o
�b� � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZm Z m
Z
m Z ddl m
Z
mZmZ ddlmZ ddlmZ dd lmZmZmZmZmZmZmZ d
d l m Z m Z d
d l m Z m!Z!m"Z"m#Z# ed
d�G dd� d��Z$dS )z
Twisted application runner.
� )�kill)�SIGTERM)�stderr)�Any�Callable�Mapping�TextIO)�Factory�attrib�attrs)�
NamedConstant)� IReactorCore)�FileLogObserver�FilteringLogObserver�Logger�LogLevel�LogLevelFilterPredicate�globalLogBeginner�textFileLogObserver� )�
ExitStatus�exit)�AlreadyRunningError�InvalidPIDFileError�IPIDFile� nonePIDFileT)�frozenc @ s� e Zd ZdZe� Zeed�Zee e
d�Z ee dd�Z
eeejd�Zeeed�Zeeegef ed�Zeed dd� d�Zeeee f e e �d�Z eed dd� d�Z eeee f e e �d�Z!dd d �Z"dd
d�Z#ddd�Z$ddd�Z%ddd�Z&ddd�Z'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)r �defaultF).Nc K � d S �N� ��_r" r" �D/usr/lib/python3/dist-packages/twisted/application/runner/_runner.py�<lambda>C � zRunner.<lambda>c K r r! r" r# r" r" r% r& E r' �returnNc C sv | j }| �� z#|� | �� | �� | �� W d � W dS 1 s#w Y W dS ty: ttjd� Y dS w )z#
Run this command.
NzAlready running.) �_pidFile�killIfRequested� startLogging� startReactor�
reactorExitedr r r � EX_CONFIG)�self�pidFiler" r" r% �runH s
&� �z
Runner.runc C s� | j }| jrP|tu rttjd� dS z|�� }W n ty( ttjd� Y dS t y7 ttj
d� Y dS w | � � | j j
d|d� t|t� ttj� dS dS )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) �_killr r r �EX_USAGE�read�OSError�EX_IOERRr �
EX_DATAERRr+ �_log�infor r �EX_OK)r/ r0 r2 r" r" r% r* [ s( �
�zRunner.killIfRequestedc C s< | j }| j}||�}t| jd�}t||g�}t�|g� dS )z=
Start the L{twisted.logger} logging system.
)�defaultLogLevelN)�_logFile�_fileLogObserverFactoryr �_defaultLogLevelr r �beginLoggingTo)r/ �logFile�fileLogObserverFactory�fileLogObserver�logLevelPredicate�filteringObserverr" r" r% r+ | s � zRunner.startLoggingc C s( | j �| j� | j�d� | j �� dS )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)�_reactor�callWhenRunning� whenRunningr9 r: r1 �r/ r" r" r% r, � s zRunner.startReactorc C � | j di | j�� dS )z�
Call C{self._whenRunning} with C{self._whenRunningArguments}.
@note: This method is called after the reactor starts running.
Nr" )� _whenRunning�_whenRunningArgumentsrI r" r" r% rH � � zRunner.whenRunningc C rJ )z�
Call C{self._reactorExited} with C{self._reactorExitedArguments}.
@note: This method is called after the reactor exits.
Nr" )�_reactorExited�_reactorExitedArgumentsrI r" r" r% r- � rM zRunner.reactorExited)r( N)(�__name__�
__module__� __qualname__�__doc__r r9 r
r
rF r r r) �boolr3 r r r: r? r r r= r r r r> rK r �strr r �dictrL rN rO r1 r* r+ r, rH r- r" r" r" r% r s*
�
!
r N)%rS �osr �signalr �sysr �typingr r r r �attrr r
r �
constantlyr �twisted.internet.interfacesr
�twisted.loggerr r r r r r r �_exitr r �_pidfiler r r r r r" r" r" r% �<module> s $