0l߃ Z d Z ddlmZmZ ddlZddlZddlZddlZddlZddl Z ddl
m Z ddl m
Z
mZmZmZ e n
# e$ r eZY nw xY weZ ej de G d d e Z G d
d ee Z G d d
ee Z G d dee Z G d d Z ddZ d Z!d Z"dS )z Daemon runner library.
)absolute_importunicode_literalsN pidfile)0_chain_exception_from_existing_exception_context
DaemonContext
basestringunicodeu@ The ‘runner’ module is not a supported API for this library.c ( e Zd ZdZ fdZd Z xZS )DaemonRunnerErrorz3 Abstract base class for errors from DaemonRunner. c b | t j |i | d S N)_chain_from_contextsuper__init__)selfargskwargs __class__s m/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/daemon/runner.pyr zDaemonRunnerError.__init__2 s7 """$)&))))) c ( t | d d S )NTas_causer r s r r z%DaemonRunnerError._chain_from_context7 s 8MMMMMMr )__name__
__module__ __qualname____doc__r r
__classcell__)r s @r r
r
/ sT ==* * * * *
N N N N N N Nr r
c e Zd ZdZd ZdS ) DaemonRunnerInvalidActionErrorz; Raised when specified action for DaemonRunner is invalid. c ( t | d d S )NFr r r s r r z2DaemonRunnerInvalidActionError._chain_from_context> s 8NNNNNNr N)r r r r! r r r r$ r$ ; s. EEO O O O Or r$ c e Zd ZdZdS ) DaemonRunnerStartFailureErrorz, Raised when failure starting DaemonRunner. Nr r r r! r& r r r( r( C 6666r r( c e Zd ZdZdS ) DaemonRunnerStopFailureErrorz, Raised when failure stopping DaemonRunner. Nr) r& r r r, r, G r* r r, c ` e Zd ZdZdZd Zd Zd ZddZd Z d Z
d
Z d Z e e e d Z
d
Zd ZdS ) DaemonRunnera4 Controller for a callable running in a separate background process.
The first command-line argument is the action to take:
* 'start': Become a daemon and call `app.run()`.
* 'stop': Exit the daemon process specified in the PID file.
* 'restart': Stop, then start.
zstarted with pid {pid:d}c | || _ t | _ | | d| _ |j t |j |j | _ | j | j _ dS )a# Set up the parameters of a new runner.
:param app: The application instance; see below.
:return: ``None``.
The `app` argument must have the following attributes:
* `stdin_path`, `stdout_path`, `stderr_path`: Filesystem paths
to open and replace the existing `sys.stdin`, `sys.stdout`,
`sys.stderr`.
* `pidfile_path`: Absolute filesystem path to a file that will
be used as the PID file for the daemon. If ``None``, no PID
file will be used.
* `pidfile_timeout`: Used as the default acquisition timeout
value supplied to the runner's PID lock file.
* `run`: Callable that will be invoked when the daemon is
started.
N)
parse_argsappr daemon_context#_open_streams_from_app_stream_pathsr pidfile_pathmake_pidlockfilepidfile_timeoutr r1 s r r zDaemonRunner.__init__X sz .
+oo 00555 '+$c&9 ; ;DL&*l###r c t |j d | j _ t |j d | j _ t |j dd | j _ dS )ab Open the `daemon_context` streams from the paths specified.
:param app: The application instance.
Open the `daemon_context` standard streams (`stdin`,
`stdout`, `stderr`) as stream objects of the appropriate
types, from each of the corresponding filesystem paths
from the `app`.
rtzw+tr ) bufferingN)open
stdin_pathr2 stdin stdout_pathstdout stderr_pathstderrr7 s r r3 z0DaemonRunner._open_streams_from_app_stream_pathsz s[ %) $>$>!%)#/5%A%A"%)!&5 &5 &5"""r c t j |d }d}d | j }d || }t | t j | dS )z Emit a usage message, then exit.
:param argv: The command-line arguments used to invoke the
program, as a sequence of strings.
:return: ``None``.
r |zusage: {progname} {usage})prognameusageN)
ospathbasenamejoin action_funcskeysformat emit_messagesysexit)r argvrE usage_exit_code action_usagemessages r _usage_exitzDaemonRunner._usage_exit s 7##DG,,xx 1 6 6 8 899 -44! 5 7 7W !!!!!r Nc | t j }d}t | |k r| | t |d | _ | j | j vr| | dS dS )a Parse command-line arguments.
:param argv: The command-line arguments used to invoke the
program, as a sequence of strings.
:return: ``None``.
The parser expects the first argument as the program name, the
second argument as the action to perform.
If the parser fails to parse the arguments, emit a usage
message and exit the program.
NrC r )rO rQ lenrU r actionrK )r rQ min_argss r r0 zDaemonRunner.parse_args s <8D t99x T " " " d1g&& ;d / / / T " " " " " 0 /r c t | j r| j | j n=# t
j $ r+ t d | j }|w xY wt j
}| j | }t | | j
dS )z Open the daemon context and run the application.
:return: ``None``.
:raises DaemonRunnerStartFailureError: If the PID file cannot
be locked by this process.
z(PID file {pidfile.path!r} already lockedr )pidN)is_pidfile_staler
break_lockr2 r; lockfile
AlreadyLockedr( rM rG getpid
start_messagerN r1 run)r errorr[ rT s r _startzDaemonRunner._start s DL ) ) & L # # % % % $ $ & & & &% 1>EE $ F . ./ /E K ikk$+++44W s A :Bc | j } t j |t j dS # t $ r+}t d || }|d}~ww xY w)z Terminate the daemon process specified in the current PID file.
:return: ``None``.
:raises DaemonRunnerStopFailureError: If terminating the daemon
fails with an OS error.
z"Failed to terminate {pid:d}: {exc})r[ excN) r read_pidrG killsignalSIGTERMOSErrorr, rM )r r[ rf rc s r _terminate_daemon_processz&DaemonRunner._terminate_daemon_process s l##%% GC ( ( ( ( ( 08?? S @ * *+ +E K s <
A1&A,,A1c | j s*t d | j }|t | j r| j dS | dS )z Exit the daemon process specified in the current PID file.
:return: ``None``.
:raises DaemonRunnerStopFailureError: If the PID file is not
already locked.
z$PID file {pidfile.path!r} not lockedr N)r is_lockedr, rM r\ r] rl )r rc s r _stopzDaemonRunner._stop s |%%'' 0:AA $ B . ./ /E K DL ) ) - L # # % % % % % * * , , , , ,r c V | | dS )z Stop, then start.
N)ro rd r s r _restartzDaemonRunner._restart s"
r )startstoprestartc | j | j }n8# t $ r+ t d | j }|w xY w|S )ae Get the function for the specified action.
:return: The function object corresponding to the specified
action.
:raises DaemonRunnerInvalidActionError: if the action is
unknown.
The action is specified by the `action` attribute, which is set
during `parse_args`.
zUnknown action: {action!r})rX )rK rX KeyErrorr$ rM )r funcrc s r _get_action_funcz DaemonRunner._get_action_func sm $T[1DD 2077 #{ 8 , ,- -E K
s 5A
c D | } || dS )z Perform the requested action.
:return: ``None``.
The action is specified by the `action` attribute, which is set
during `parse_args`.
N)rx )r rw s r do_actionzDaemonRunner.do_action s& $$&& T
r r )r r r r! ra r r3 rU r0 rd rl ro rq rK rx rz r& r r r. r. K s /M 3 3 3D
5
5
5 " " " # # # #4 2 "- - -& L *
r r. c | t j }| d | | dS )z@ Emit a message to the specified stream (default `sys.stderr`). Nz
{message}
)rT )rO rA writerM flush)rT streams r rN rN sB
~
LL %%g%66777
LLNNNNNr c , t | t s%t d | }|t j | s%t d | }|t j | | }|S )z= Make a PIDLockFile instance with the given filesystem path. z Not a filesystem path: {path!r})rH z Not an absolute path: {path!r})
isinstancer
ValueErrorrM rG rH isabsr TimeoutPIDLockFile)rH acquire_timeoutrc r^ s r r5 r5 & s dJ ' ' <CC D
7== ;BB C )$@@H Or c d} | j }|\ t j |t j n;# t
$ r d}Y n-t $ r!}|j t j k rd}Y d}~nd}~ww xY w|S )u Determine whether a PID file is stale.
:return: ``True`` iff the PID file is stale; otherwise ``False``.
The PID file is “stale” if its contents are valid but do not
match the PID of a currently-running process.
FNT) rg rG rh ri SIG_DFLProcessLookupErrorrk errnoESRCH)r result pidfile_pidrf s r r\ r\ 5 s F"'"$$K GK 0 0 0 0! FFF yEK'' Ms 5 A- A- A((A-r )#r!
__future__r r r rG ri rO warningsr^ r daemonr r r
r r NameErrorNotImplementedtype
__metaclass__warnDeprecationWarning Exceptionr
r r$ RuntimeErrorr( r, r. rN r5 r\ r& r r r s5 ; : : : : : : :
( ( ( ('(
J
N N N N N N N NO O O O O%6
O O O7 7 7 7 7$5| 7 7 77 7 7 7 7#4l 7 7 7P P P P P P P Pf s 9 AA