File: //lib/python3.6/site-packages/ipaplatform/base/__pycache__/services.cpython-36.pyc
3
�d[e�I � @ s. d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z ddl
mZ ddlmZ eje�Zdd d
d d d
ddddddddddddddd d d d d d!d"d#d$d%d&g Zd'gd(d)gd(d)gd(d)gd*�Zd+ZG d,d-� d-e�ZG d.d/� d/�ZG d0d1� d1e�Zd5d2d3�ZeZei �Z ddd4gZ dS )6zj
This base module contains default implementations of IPA interface for
interacting with system services.
� )�absolute_importN)�ipautil)�paths)�tasks)�MappingZ
certmonger�dirsrvZhttpdZipaZkrb5kdcZdbusZnslcdZnscdZntpdZportmapZrpcbindZkadminZsshdZautofsZrpcgssdZ rpcidmapdZ pki_tomcatdZchronydZ
domainnameZnamedZ
ods_enforcerdZ ods_signerdZgssproxyz nfs-utilsZsssdZNetworkManagerz ipa-custodiazipa-dnskeysyncdzipa-otpdzipa-ods-exporterzsystemd-resolvedi� i� i� )r z [email protected]
pki-tomcatz pki-tomcatdg�������?c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dS )�
KnownServicesz�
KnownServices is an abstract class factory that should give out instances
of well-known platform services. Actual implementation must create these
instances as its own attributes on first access (or instance creation)
and cache them.
c C s
|| _ d S )N)�_KnownServices__d)�self�d� r � /usr/lib/python3.6/services.py�__init__N s zKnownServices.__init__c C s
| j | S )N)r )r
�keyr r r
� __getitem__Q s zKnownServices.__getitem__c C s
t | j�S )N)�iterr )r
r r r
�__iter__T s zKnownServices.__iter__c C s
t | j�S )N)�lenr )r
r r r
�__len__W s zKnownServices.__len__c C s t j| j�S )N)�sixZ
itervaluesr )r
r r r
�__call__Z s zKnownServices.__call__c C s, y
| j | S tk
r& t|��Y nX d S )N)r �KeyError�AttributeError)r
�namer r r
� __getattr__] s
zKnownServices.__getattr__N)
�__name__�
__module__� __qualname__�__doc__r r r r r r r r r r
r G s r c @ s� e Zd ZdZd%dd�Zd&dd�Zd'd d
�Zd(d d �Zd)d
d�Zd*dd�Z d+dd�Z
dd� Z d,dd�Z d-dd�Z
d.dd�Zd/dd �Zd0d d �Zd1d d �Zd2d!d"�Zd3d#d$�ZdS )4�PlatformServicez�
PlatformService abstracts out external process running on the system
which is possible to administer (start, stop, check status, etc).
Nc C sB dd l }|| _|d k r || _n |j| _tjdj| d�tdd� d S )Nr zC{s.__class__.__name__}('{s.service_name}', api=None) is deprecated.)�s� )�
stacklevel)�ipalib� service_name�api�warnings�warn�format�RuntimeWarning)r
r$ r% r# r r r
r k s zPlatformService.__init__� Tc C s� |sdS g }y&t tjd��}tj|�}W dQ R X W n tk
rF Y nX | j|kr^|j| j� t tjd��}tj||� W dQ R X dS )z�
When a service is started record the fact in a special file.
This allows ipactl stop to always stop all services that have
been started via ipa tools
N�r�w) �openr �
SVC_LIST_FILE�json�load� Exceptionr$ �append�dump)r
�
instance_name�capture_output�wait�update_service_list�svc_list�fr r r
�starty s
zPlatformService.startc C s� |sdS g }y&t tjd��}tj|�}W dQ R X W n tk
rF Y nX x| j|krb|j| j� qJW t tjd��}tj||� W dQ R X dS )zQ
When a service is stopped remove it from the service list file.
Nr+ r, ) r- r r. r/ r0 r1 r$ �remover3 )r
r4 r5 r7 r8 r9 r r r
�stop� s zPlatformService.stopc C s d S )Nr )r
r4 r5 r6 r r r
�reload_or_restart� s z!PlatformService.reload_or_restartc C s d S )Nr )r
r4 r5 r6 r r r
�restart� s zPlatformService.restartc C s d S )Nr )r
r4 r5 r6 r r r
� try_restart� s zPlatformService.try_restartc C s dS )NFr )r
r4 r6 r r r
�
is_running� s zPlatformService.is_runningc C s dS )NFr )r
r r r
� is_installed� s z PlatformService.is_installedc C s dS )NFr )r
r4 r r r
�
is_enabled� s zPlatformService.is_enabledc C s dS )NFr )r
r4 r r r
� is_masked� s zPlatformService.is_maskedc C s d S )Nr )r
r4 r r r
�enable� s zPlatformService.enablec C s d S )Nr )r
r4 r r r
�disable� s zPlatformService.disablec C s d S )Nr )r
r4 r r r
�mask� s zPlatformService.maskc C s d S )Nr )r
r4 r r r
�unmask� s zPlatformService.unmaskc C s d S )Nr )r
r4 r r r
�install� s zPlatformService.installc C s d S )Nr )r
r4 r r r
r; � s zPlatformService.remove)N)r* TTT)r* TT)r* TT)r* TT)r* TT)r* T)r* )r* )r* )r* )r* )r* )r* )r* )r r r r r r: r< r= r> r? r@ rA rB rC rD rE rF rG rH r; r r r r
r d s(
r c s� e Zd ZdZd0� fdd� Zd1dd�Zd2dd�Zd3d
d �Zd4� fd
d� Zd5� fdd� Z d6dd�Z
d7dd�Z d8dd�Z d9dd�Z
d:dd�Zd d � Zd;d d �Zd<d d!�Zd=d"d#�Zd>d$d%�Zd?d&d'�Zd@d(d)�ZdAd*d+�Zd,d-� Zd.d/� Z� ZS )B�SystemdServicez%s.target.wantsNc s8 t t| �j||d� || _tjjtj| j�| _ d | _
d S )N)r% ) �superrI r � systemd_name�os�path�joinr �LIB_SYSTEMD_SYSTEMD_DIR�lib_path�lib_path_exists)r
r$ rK r% )� __class__r r
r � s
zSystemdService.__init__c C s� | j d krtjj| j�| _ | jjd�}|d dkrR| rRdt| jj j
j dd�� S | j r�|r�t |�dkrn| jS t |�dkr�|d d dkr�| jS t |�dkr�|r�d|d |f S d |d }tjj
tj|�}tjj|�r�|S | jS )
N�@r r zdirsrv@%s.service�.�-� z
%s@%s.servicez %s.target)rQ rL rM �existsrP rK �split�strr% �envZrealm�replacer rN r rO )r
r4 � operation�elementsZtgt_nameZsrv_libr r r
�service_instance� s&
z SystemdService.service_instancec s( ddd��t � �fdd�|jd�D ��S )a
Parses 'systemctl show' output and returns a dict[variable]=value
Arguments: text -- 'systemctl show' output as string
separator -- optional (defaults to None), what separates
the key/value pairs in the text
Nc S s* t | �dkr&| j|�}|d |d fS dS )NrV r ���)NN)r rX )�x� separator�yr r r
�splitter s
z0SystemdService.parse_variables.<locals>.splitterc 3 s | ]}�|� d �V qdS ))ra Nr )�.0r` )ra rc r r
� <genexpr>
s z1SystemdService.parse_variables.<locals>.<genexpr>�
)N)�dictrX )r
�textra r )ra rc r
�parse_variables� s
z SystemdService.parse_variablesr* c C sV d}|t krt | }n$| jjd�}|d t kr:t |d }|rRtjd|| jjj� dS )zA
If this is a service we need to wait for do so.
NrS r Z localhost)�wellknownportsrK rX r �wait_for_open_portsr% rZ Zstartup_timeout)r
r4 Zportsr] r r r
rk s
z"SystemdService.wait_for_open_portsTc sp | j |�}tjd|g}|dkr(|jd� tj|| d� t| jjdd �d
k}t t
| �j ||d� t j
d |� d S ) Nr< zipa-otpd.socketz--ignore-dependencies)� skip_output�context�ipactl� installer)r7 zStop of %s complete)rn ro )r^ r � SYSTEMCTLr2 r �run�getattrr% rZ rJ rI r< �logger�debug)r
r4 r5 �instance�argsr7 )rR r r
r< s
zSystemdService.stopc sz t jtjd| j|�g| d� t| jjdd �dk}|rP| j|�rP| j | j|�� t
t | �j ||d� t
jd| j|�� d S ) Nr: )rl rm rn ro )r7 zStart of %s complete)rn ro )r rq r rp r^ rr r% rZ r@ rk rJ rI r: rs rt )r
r4 r5 r6 r7 )rR r r
r: / s
zSystemdService.startFc C sR t jtj|| j|�g| d� |r<| j|�r<| j| j|�� tjd| j|�� d S )N)rl zRestart of %s complete) r rq r rp r^ r@ rk rs rt )r
r4 r\ r5 r6 r r r
�
_restart_base? s
z SystemdService._restart_basec C s | j |d||� d S )Nzreload-or-restart)rw )r
r4 r5 r6 r r r
r= K s z SystemdService.reload_or_restartc C s | j |d||� d S )Nr> )rw )r
r4 r5 r6 r r r
r> P s zSystemdService.restartc C s | j |d||� d S )Nz try-restart)rw )r
r4 r5 r6 r r r
r? T s zSystemdService.try_restartc C s� | j |d�}x�ytjtjd|gdd�}W nF tjk
rn } z(|jdkr`dt|j�kr`t j
t � wdS d }~X qX |jdkr�d|jkr�t j
t � q|jdkr�dS dS qW d S )Nz is-activeT)r5 � Z
activatingFr ) r^ r rq r rp �CalledProcessError�
returncoderY �output�timeZsleep�SERVICE_POLL_INTERVAL)r
r4 r6 ru �result�er r r
r@ X s"
zSystemdService.is_runningc C sb yFt jtjddgdd�}|jdkr&dS | j|j�}| jd�|krDdS W n t jk
r\ dS X dS )Nzlist-unit-filesz--fullT)r5 r Fr* ) r rq r rp rz ri r{ r^ ry )r
r~ Zsvarr r r
rA q s
zSystemdService.is_installedc C sN d}y*t jtjd| j|�g�}|jdkr,d}W n t jk
rH d}Y nX |S )NTz
is-enabledr F)r rq r rp r^ rz ry )r
r4 Zenabledr~ r r r
rB � s
zSystemdService.is_enabledc C sX d}y8t jtjd| j|�gdd�}|jdkr:|jdkr:d}W n t jk
rR Y nX |S )NFz
is-enabledT)r5 rV �masked)r rq r rp r^ rz r{ ry )r
r4 r� r~ r r r
rC � s
zSystemdService.is_maskedc C sh | j d krtjj| j�| _ | jjd�}t|�}| j rZ|dkrZ|d d dkrZ| j|� d S | j rt|dkrt| j� d S t|�dko�|dk�rZtjj t
j | j |d �}tjj || j
|��}y�tjj|�s�tj|� tj|d� tjj|�r�tj|� tjj|��s6tjj|��s tj| j|� ntj|� tj| j|� tj� W n tk
�rV Y nX n
| j|� d S )NrS rV r rT i� )rQ rL rM rW rP rK rX r �_SystemdService__enablerN r �ETC_SYSTEMD_SYSTEM_DIR�SYSTEMD_SRV_TARGETr^ �isdir�mkdir�chmod�unlink�islink�symlinkr �systemd_daemon_reloadr1 )r
r4 r] �l�srv_tgt�srv_lnkr r r
rD � s<
zSystemdService.enablec C s� | j jd�}|dkr�t|�dkr�tjjtj| j|d �}tjj|| j |��}y.tjj
|�rrtjj |�rrtj |� t
j� W q� tk
r� Y q�X n4y tjtjd| j |�g� W n tjk
r� Y nX d S )NrS r* rV r rE )rK rX r rL rM rN r r� r� r^ r� r� r� r r� r1 r rq rp ry )r
r4 r] r� r� r r r
rE � s$
zSystemdService.disablec C sd t jjtj| j|��}t jj|�r,t j|� y tj tj
d| j|�g� W n tj k
r^ Y nX d S )NrF ) rL rM rN r r� r^ rW r� r rq rp ry )r
r4 r� r r r
rF � s
zSystemdService.maskc C s8 y t jtjd| j|�g� W n t jk
r2 Y nX d S )NrG )r rq r rp r^ ry )r
r4 r r r
rG � s
zSystemdService.unmaskc C s8 y t jtjd| j|�g� W n t jk
r2 Y nX d S )NrD )r rq r rp r^ ry )r
r4 r r r
Z__enable s
zSystemdService.__enablec C s | j � d S )N)rD )r
r r r
rH s zSystemdService.installc C s | j � d S )N)rE )r
r r r
r;
s zSystemdService.remove)N)N)N)r* )r* T)r* TT)TF)r* TT)r* TT)r* TT)r* T)r* )r* )r* )r* )r* )r* )r* )r r r r� r r^ ri rk r< r: rw r= r> r? r@ rA rB rC rD rE rF rG r� rH r; �
__classcell__r r )rR r
rI � s0
$
5
rI c C s t �d S )N)�NotImplementedError)r r% r r r
�base_service_class_factory s r� zsystemd-timesyncd)N) r Z
__future__r rL r/ r| Zloggingr& r Z ipapythonr Zipaplatform.pathsr Zipaplatform.tasksr �collections.abcr Z getLoggerr rs Zwellknownservicesrj r} r r rI r� ZserviceZ
knownservicesZtimedate_servicesr r r r
�<module> sD
j D