File: //var/opt/nydus/ops/primordial/service/__pycache__/base_daemon.cpython-39.pyc
a
�,�h� � @ sH d dl Z d dlmZmZmZ d dlmZmZ e �e �Z
G dd� d�Z dS )� N)�PIPE�call�CalledProcessError)�Any�Dictc @ sp e Zd ZdZeedd�dd�Zdeeeed�dd �Zed
�d d �Z ed
�d
d�Z
ed
�dd�Z ed
�dd�Z dS )�
BaseDaemonz!A base implementation of a daemonN)�name� command_fmt�returnc C s || _ || _d S )N)r r )�selfr r � r �O/opt/nydus/tmp/pip-target-wkfpz8uv/lib/python/primordial/service/base_daemon.py�__init__
s zBaseDaemon.__init__T)�action�check_return_code�pipesr
c C sz t �d|| j� ddd�}|r.|�ttd�� | jj| j|d�}t|�� fi |��}t �|� |rv|dkrvt ||d��|S ) a Run an action for the daemon.
:param action: The action to be run
:param check_return_code: Whether to error on non-zero return codes
:param pipes:
:raises CalledProcessError: If `check_return_code` is True, and a non-zero return code occurs
z%sing %sT�
)�universal_newlines�timeout)�stdout�stderr)r r r )�
returncode�cmd)
�LOGGER�infor �updater r �formatr �splitr )r r r r �kwargsr �resultr r r
�_run s
zBaseDaemon._run)r
c C s | j ddd�S )z Check the status of the daemon.�statusF)r �r �r r r r
r! % s zBaseDaemon.statusc C s | j ddd�S )zStart the daemon.�startF�r r" r# r r r
r$ ) s zBaseDaemon.startc C s
| � d�S )zStop the daemon.�stopr" r# r r r
r& / s zBaseDaemon.stopc C s | j ddd�S )zRestart the daemon.�restartFr% r" r# r r r
r' 3 s zBaseDaemon.restart)TT)
�__name__�
__module__� __qualname__�__doc__�strr �boolr r r! r$ r& r' r r r r
r s r ) �logging�
subprocessr r r �typingr r � getLoggerr( r r r r r r
�<module> s