3
�Qf�} � + @ s� d dl mZ d dlmZ ddddddd d
d d d
ddddddddddddddd d d d d d!d"d#d$d%d&d'd(d)d*d+d,d-g+Zd d.lZd d.lZd d.lZd d/lm Z d d.l
Z
d d0l m Z d d.l
Z
d d.lZd d.lZd d.lZd d.lZd d.lZd d.lZd d.lZd d.lZd d1lT d d.lZd d2lmZ d d3lmZmZ d d4l m Z d d1l T d5d6� Z d7d8� Z d9Z!d Z"d.Z#ej$d:��r`d:Z#nej$d;��rpd<Z#d=Z%ej&� Z'ej(d>�Z)ej(d?�Z*ej(d@�Z+ej(dA�Z,ej(dB�Z-ej(dC�Z.d.a/ej0a1ej2ej3ej0ej4ej5dD�Z6dEdF� Z7dGd#� Z8dHd*� Z9dId)� Z:dJd� Z;dKd� Z<dLd� Z=dMd� Z>d�dNd�Z?dOd� Z@d�dRd�ZAd�dSd �ZBd�dUd
�ZCdVd � ZDdWd � ZEdXd
� ZFdYd� ZGdZd� ZHd[d� ZId\d� ZJyd d]lKmLZL eL� ZMW n g ZMY nX d^d� ZNd_d� ZOd`da� ZPdbdc� ZQd�ded�ZRdfd� ZSdgd� ZTdhd � ZUdid!� ZVdjd$� ZWd�dkd%�ZXdld"� ZYd�dmd�ZZdndo� Z[d�dpd�Z\dqd� Z]d�drd �Z^dsd � Z_dtd � Z`dud � Zadvd&� Zbejcejd dw�Zeejf�r�ejcejg dw�ZhneeZhehee Ziejcd �Zjejcdxdy�ZkG dzd{� d{ejl�ZmG d|d}� d}ejl�ZnG d~d+� d+�ZoG dd,� d,e j �Zpe jqep� d.S )�� )�absolute_import)�range�audit_msg_decode� merge_lists�preextend_list�fmt_obj�format_elapsed_time�format_2_column_name_value� wrap_text�
format_msg�remove_linebreaks� default_text�default_date_text�get_standard_directories�get_rpm_nvr_from_header�get_package_nvr_by_name� get_package_nvr_by_file_path�get_rpm_nvr_by_type�get_rpm_nvr_by_scontext�get_rpm_source_package�is_hex�
split_rpm_nvr�
file_types�get_user_home_dir�get_plugin_names� load_plugins�get_os_environment� find_program� get_identity� get_hostname�make_database_filepath�valid_email_address�launch_web_browser_on_url�abstract� log_debug� get_error_from_socket_exception�!assure_file_ownership_permissions�parse_datetime_offset�DATABASE_MAJOR_VERSION�DATABASE_MINOR_VERSION�database_version_compatible� syslog_trace� TimeStamp�Retry�PACKAGE_MANAGERN)� SystemBus)�GObject)�*)�
cmp_to_key)� FunctionType�
MethodType)�
get_configc C s | |k| |k S )N� )�x�yr6 r6 �/usr/lib/python3.6/util.py�<lambda>\ s r: c C s* y
t | t�S tk
r$ t | t�S X d S )N)�
isinstanceZTypeType� NameError�type)�objr6 r6 r9 �is_type_ s
r? � �rpm�dpkg�debz/etc/redhat-releasez \s*\n+\s*z^[A-Fa-f0-9]+$z <a\s*href="([^"]+)"[^<]*</a>z^([^\s@]+)@([^\s@]+)$z^\s*"([^"]+)"\s*$z \s*\(\s*type\s+([\w-]+)\s*\)\s*)ZCRITICALZERRORZWARNING�INFO�DEBUGc C s& t jt| d�j� �atd kr"tjad S )N�level)�
log_levels�getr5 �upper� log_level�syslog� LOG_WARNING)Zsectionr6 r6 r9 �log_init� s rM c C s t tjkrtjtj| � d S )N)rJ rK � LOG_DEBUG)�msgr6 r6 r9 r$ � s
c C s. | j d�}x |D ]}t|�rtj|� qW d S )N�
)�split�lenrK )ZtraceZ log_lines�liner6 r6 r9 r+ � s
c C sz d }}| j d�}t|�dkr*t|d �}t|�dkrBt|d �}|tk r`td| ttf � dS td| ttf � dS d S ) N�.� r � z=database version %s not compatible with current %d.%d versionFz9database version %s compatible with current %d.%d versionT)rQ rR �intr( r$ r) )�version�major�minor�
componentsr6 r6 r9 r* � s
c C s� | d kr d S dd l }|j| �\}}t|�}|d }||d }|d }||d }|d }||d }|r~d||||| f S |r�d|||| f S |r�d||| f S d|| S ) Nr i�Q i �< z%dd:%dh:%dm:%.3fsz
%dh:%dm:%.3fsz %dm:%.3fsz%.3fs)�mathZmodfrW )Z elapsed_timer] ZfractionZwhole�days�hours�minutes�secondsr6 r6 r9 r � s$ c C s t j| �rdS dS d S )NTF)�hex_re�match)�strr6 r6 r9 r � s
c C sj | d kr d S t j| �}|r&|jd�}n@y.tjd dk rB| jd�}ntj| �jd�}W n | }Y nX |S )NrU r r@ �hexzutf-8)�audit_decode_re�search�group�sys� version_info�decode� bytearray�fromhex)rO rc Zdecodedr6 r6 r9 r � s
c C sP |s| S | s|S i }x| D ] }d||< qW x|D ] }d||< q0W t |j� �}|S )z2return a list containing the unique members of a+bN)�list�keys)�a�b�d�i�mr6 r6 r9 r � s
c s^ |d kr g }t |�}| | }|dkrZt� �rJ|j� fdd�t|�D �� n|j� g| � |S )Nr c s g | ]
}� � �qS r6 r6 )�.0r7 )�defaultr6 r9 �
<listcomp>� s z"preextend_list.<locals>.<listcomp>)rR r? �extendr )Zrequested_lengthZ_listrv Z
cur_lengthZdeltar6 )rv r9 r � s c s� t � tj�r� S t � ttf�r:ddjdd� � D �� d S t � t�rxt� j� �}|j� ddj� fdd�|D �� d S t � �S d S ) N�[� c S s g | ]}d t |� �qS )z%s)r )ru r7 r6 r6 r9 rw s zfmt_obj.<locals>.<listcomp>�]�{c s$ g | ] }d t |�t � | �f �qS )z%s=%s)r )ru �key)r> r6 r9 rw s �})
r; �six� string_typesrn �tuple�join�dictro �sortrd )r> ro r6 )r> r9 r � s
� �P c C sx t | �|kr"| d|d � d }n| d|t | � }| sD|j� rP|| d S |t_d| t_|t_tj|�d S d S )Nr rU rz rP )rR �isspace� text_wrapper�initial_indent�subsequent_indent�width�fill)�name�valueZ value_indentZ
page_widthr� r6 r6 r9 r s
c C s( d| }|t _|t _|t _t j| �d S )Nrz rP )r� r� r� r� r� )�sr� �indent�prefixr6 r6 r9 r
s
� c C sD |d kr d}|j � }d| }|t_|t_dt_| d tj|� d S )N� rz r� rP z
)�stripr� r� r� r� r� )�titlerO r� Z indentStringr6 r6 r9 r # s c C s$ t jd| �j� }|d kr dS |S d S )Nrz r� )�fix_newline_re�subr� )rd Znew_strr6 r6 r9 r . s c C s | d krdt d� d } t| �S )N�<ZUnknown�>)�_rd )�valr6 r6 r9 r
6 s c C s | d krt | �S | j� S )N)r
�format)Zdater6 r6 r9 r < s c
C sz g } yPt dkr,tjdddgdd�j� jd�} t dkrRtjdd d
gdd�j� jd�} W n tjtjd jt �� Y nX | S ) z3
>>> get_standard_directories()
[...'/bin'...]
rA z-qlZ
filesystemT)�universal_newlinesrP rC rB z-Lz
base-fileszfailed to get list from {})r. �
subprocess� check_output�rstriprQ rK �LOG_ERRr� )Zlstr6 r6 r9 r B s "c C s& | d }| d }| d }d|||f S )z6Given an RPM header return the package NVR as a stringr� rX �releasez%s-%s-%sr6 )Zhdrr� rX r� r6 r6 r9 r T s c C sz | dkr dS d}yFt dkr2tjdd| gdd�j� }t dkrTtjddd | gdd�j� }W n tjtjd
| � Y nX |S ) zJ
>>> get_package_nvr_by_name("coreutils")
'coreutils-8.30-3+b1:amd64'
NrA z-qT)r� rC z
dpkg-queryz(-f=${Package}-${Version}:${Architecture}z-Wz"failed to retrieve rpm info for %s)r. r� r� r� rK r� )r� �nvrr6 r6 r9 r \ s c C s� | dkr dS t jj| �} t jj| �s(dS d}ydtdkrNtjdd| gdd�j� }tdkr�tjdd| g�j� j d �d
}tjd d d
|gdd�j� }W n t
j
t
j d| � Y nX |S )zM
>>> get_package_nvr_by_file_path("/bin/ls")
'coreutils-8.30-3+b1:amd64'
NrA z-qfT)r� rC rB z-Sz: r z
dpkg-queryz(-f=${Package}-${Version}:${Architecture}z-Wz"failed to retrieve rpm info for %s) �os�path�abspath�existsr. r� r� r� rk rQ rK r� )r� r� Z package_namer6 r6 r9 r r s )�get_all_file_typesc C s6 | j d�}|d }|d }dj|d d� �}|||fS )N�-rU rV ������r� )rQ r� )r� r[ r� rX r� r6 r6 r9 r � s
c C s. t dkrt� t dkrdS t j| d�}t|�S )aV
Finds an SELinux module which defines given SELinux type
##### arguments
* `selinux_type(s)`: an SELinux type
##### return values
* `nvr(s)`: nvr of rpm which ships module where `selinux_type` is defined
##### usage
>>> get_rpm_nvr_by_type("sshd_t")
'selinux-policy-...
>>> get_rpm_nvr_by_type("mysqld_log_t")
'mysql-selinux-...
N)�module_type_cache�build_module_type_cacherH r )Z selinux_typer� r6 r6 r9 r � s c C s y t | � dS dS d S )NTF)rW )rd r6 r6 r9 � __str_is_int� s
r� c C s t j� \} }| dkrdS t� }g }tjdj|��� }tdd� |D �dd� d�}W dQ R X x�|D ]�}x�tjd j||��D ]�\}}}d
|krvyjytj d j|�d d
�} W n t d j|��} Y nX x(| D ] }
t
j |
�} | r�||| j d�< q�W | j
� W qv Y qvX qvW q^W |adS )z�
Creates a dictionary with all types defined in the module store as keys
and corresponding module paths as values.
The dictionary is stored in "module_type_cache" to be used by
"get_rpm_nvr_by_type"
r Nz"/var/lib/selinux/{}/active/modulesc S s$ g | ] }|j � rt|j�r|j�qS r6 )�is_dirr� r� )ru r7 r6 r6 r9 rw � s z+build_module_type_cache.<locals>.<listcomp>c S s t | �S )N)rW )r7 r6 r6 r9 r: � s z)build_module_type_cache.<locals>.<lambda>)r} z%/var/lib/selinux/{}/active/modules/{}Zcilz{}/cilZrt)�moderU )�selinuxZselinux_getpolicytyper� r� �scandirr� �sorted�walk�bz2�open�typedef_regexprc rh �closer� ) ZretvalZ
policytypeZmodule_type_dictZ
prioritiesZ module_store�dir�dirpathZdirnames� filenames�frS �resultr6 r6 r9 r� � s. $
r� Fc C sJ |r&t � }|jd�}t|jt| ���S tjt| ��}tttj|���S dS )a
Finds an SELinux module which defines given SELinux context
##### arguments
* `scontext(s)`: an SELinux context
##### return values
* `nvr(s)`: nvr of rpm which ships module where SELinux type used in `scontext` is defined
##### usage
>>> get_rpm_nvr_by_scontext("system_u:system_r:syslogd_t:s0")
'selinux-policy-...
>>> get_rpm_nvr_by_scontext("system_u:system_r:mysqld_log_t:s0")
'mysql-selinux-...
>>> get_rpm_nvr_by_scontext("system_u:system_r:timedatex_t:s0", use_dbus=True)
'selinux-policy-...
z*org.fedoraproject.SetroubleshootPrivilegedN)r/ rH rd r r� Z context_newr Zcontext_type_get)ZscontextZuse_dbusZbusZ
remote_object�contextr6 r6 r9 r � s
c C sd | dkr dS d}y0ddl }|jdddd| gdd�jd d
�d }W n tjtjd | � Y nX |S ) z�
Find a source package for `name` rpm
>>> get_rpm_source_package("policycoreutils-python-utils")
'policycoreutils'
>>> get_rpm_source_package("selinux-policy-targeted")
'selinux-policy'
Nr rA z-qz--qfz %{SOURCERPM}T)r� r� rV z"failed to retrieve rpm info for %s)r� r� �rsplitrK r� )r� �srcr� r6 r6 r9 r s (c C s6 t j� } ytj| �}W n tk
r* d S X |j}|S )N)r� �getuid�pwd�getpwuid�KeyError�pw_dir)�uidZpwZhome_dirr6 r6 r9 r + s c C s t j| �}|rdS dS d S )NTF)�name_at_domain_rerg )Zaddressrc r6 r6 r9 r! 5 s
c C s t dd�}tjtj||| � d S )NZ helper_apps�web_browser_launcher)r5 r� �spawnl�P_NOWAIT)Zurlr� r6 r6 r9 r" = s
c C s6 t | dd �}|r"|d }|d }n t}t|�}||fS )N�argsr rU )�getattrZERR_SOCKET_ERRORZ get_strerror)�er� �errno�strerrorr6 r6 r9 r% B s
c
/ C s� d}t jj| �sfyt| d�}|j� W n> tk
rd } z"d}tjtjd| |jf � W Y d d }~X nX yt j | |� W n@ t
k
r� } z$d}tjtjd| ||jf � W Y d d }~X nX ybt |t �r�|}nt
j|�d }|d kr�|}t |t �r�|}ndd l} | j|�d }t j| ||� W n` t
k
�rz } zBd}dd l} tjtjd| t
j|�d | j|�d |jf � W Y d d }~X nX |S ) NT�wFzcannot create file %s [%s]zcannot chmod %s to %o [%s]rV r z cannot chown %s to %s:%s [%s])r� r� r� r� r� � ExceptionrK r� r� �chmod�OSErrorr; rW r� �getpwnam�grpZgetgrnam�chownr� Zgetgrgid)
�filepathr� �ownerrh r� r� r� r� �gidr� r6 r6 r9 r& M s:
*,
Bc C s< dd l }|j|j� �d d }| jj}td|||f ��d S )Nr rU r@ z=%s must be implemented in subclass %s or ancestor class of %s)�inspectZgetouterframesZ currentframe� __class__�__name__�NotImplementedError)r> r� �method�subclassr6 r6 r9 r# w s
c C s� | d krd} nt jdd| �} tdd�}g }xXtjtjj|| d ��D ]<}tjj|�}|d kr^qDtjjtjj|��d }|j |� qDW |S )
Nr1 z.py$r� �plugins�
plugin_dirz.py� __init__.pyr )r� )
�rer� r5 �globr� r� r� �basename�splitext�append)� filter_globr� � plugin_names�p� plugin_namer6 r6 r9 r � s
c C s | j � |j � S )N)Z get_priority)r7 r8 r6 r6 r9 � sort_plugins� s r� c C sv t dd�}tjj|�}g }t| �}td| � |}d}|tjkr�y0dd l}|j ||g�\}} }
|j
||| |
�} W n& t k
r� t j t j
d| � g S X |r�|j� x�|D ]�}d||f }tjj|�} | d k r�td| � |j| j� � q�y>dd l}|j ||g�\}} }
|j
||| |
�} |j| j� � W n( t k
�rP t j t j
d | � Y nX |r�|j� q�W |jtt�d
� |S ) Nr� r� zload_plugins() names=%s�__init__r z"failed to initialize plugins in %sz%s.%sz%load_plugins() %s previously importedzfailed to load %s plugin)r} )r5 r� r� r� r r$ ri �modules�imp� find_module� load_moduler� rK r� r� rH r� Zpluginr� r2 r� ) r� r� Z plugin_baser� r� Z module_namer� r� Zmod_fpZmod_pathZmod_description�modr6 r6 r9 r � sF
c C s~ yt t�j� d j� } W n8 ydd l}dj|j� �} W n d} Y nX Y nX tj� }|d }|d }d||f }| |fS )Nr rz �unknownrV r� z%s %s) r� �redhat_release_path� readlinesr� �distror� Zlinux_distributionr� �uname)Z
myplatformr� r� Zkernel_releaseZcpuZos_descr6 r6 r9 r � s c C s@ | d krt j� } ytj| �}W n tk
r2 d S X |d }|S )Nr )r� r� r� r� r� )r� Z pwd_entryZusernamer6 r6 r9 r � s c C sL ydd l } | j� }|S tk
rF } ztjtjd| � d S d }~X nX d S )Nr zcannot lookup hostname: %s)ZsocketZ gethostnamer� rK r� )ZSocketZhostnamer� r6 r6 r9 r � s c C s\ t jj| �r| S t jj| �}tdd�jd�}x*|D ]"}t jj||�}t jj|�r2|S q2W d S )NZ fix_commandZprog_search_path�:)r� r� �isabsr� r5 rQ r� r� )�progr� Z search_pathrr r� r6 r6 r9 r � s
c C s2 t dd�}tjdd| �} | d }tjj||�}|S )NZdatabase� database_dirz\.xml$r� z
_database.xml)r5 r� r� r� r� r� )r� r� �filenamer� r6 r6 r9 r � s
c C s$ t jd�}d}d}d}d}d}| j� } x�|j| �D ]�}|r2d}t|jd��}|jd�} | dk r2| dkrr||d 7 }| d
kr�||d 7 }| d kr�||d
7 }| dkr�||7 }| dkr�||7 }| dkr�||7 }| dkr2||7 }q2W |�r
tj||||d�}
td| |
f � |
S t j t j
d| � dS dS )z�The time offset may be specified as a sequence of integer unit pairs.
Units may be one of year,month,week,day,hour,minute,second and may optionally be plural.
Example: '2 weeks 1 day' sets the threshold at 15 days.
z0(\d+)\s*(year|month|week|day|hour|minute|second)Fr TrU rV N�yearim �month� Zweek� �day�hour�minute�second)r^ r_ r` ra z)parse_datetime_offset(%s) = time delta %sz$could not parse datetime offset (%s)) r� �compile�lower�finditerrW rh �datetime� timedeltar$ rK r� ) �textZdatetime_offset_re�foundr^ r_ r` ra rc ZquantityZunitZtdr6 r6 r9 r' sB
)ra rU )r_ c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�
LocalTimezonec C s | j |�rtS tS d S )N)�_isdst� DSTOFFSET� STDOFFSET)�self�dtr6 r6 r9 � utcoffset= s
zLocalTimezone.utcoffsetc C s | j |�rtS tS d S )N)r
�DSTDIFF�ZERO)r r r6 r6 r9 �dstC s
zLocalTimezone.dstc C s t j| j|� S )N)�time�tznamer
)r r r6 r6 r9 r I s zLocalTimezone.tznamec C sD |j |j|j|j|j|j|j� ddf }tj|�}tj |�}|j
dkS )Nr rU r� ) r� r� r r r r �weekdayr ZmktimeZ localtimeZtm_isdst)r r ZttZstampr6 r6 r9 r
L s
zLocalTimezone._isdstN)r� �
__module__� __qualname__r r r r
r6 r6 r6 r9 r ; s r c @ s( e Zd Zd Zdd� Zdd� Zdd� ZdS )�UTCc C s
t jd�S )Nr )r r )r r r6 r6 r9 r X s z
UTC.utcoffsetc C s dS )Nr r6 )r r r6 r6 r9 r [ s z
UTC.tznamec C s
t jd�S )Nr )r r )r r r6 r6 r9 r ^ s zUTC.dstN)r� r r �__doc__r r r r6 r6 r6 r9 r U s r c @ s� e Zd Ze� Ze� ZdZdZd#dd�Z dd� Z
dd � Z d
d � Z d d
� Z
dd� Zd$dd�Zdd� Zdd� Zdd� Zd%dd�Zd d � Zd d � Zd&d!d"�ZdS )'r, z%Y-%m-%dT%H:%M:%SZz%cNc C s� |d kr| j dd�| _nft|tj�r0| j|� nNt|t�rNtjj|| j �| _n0t|tj�rb|| _n t|t
�rv|j| _nt d��d S )NF)�localz-must be string, float, datetime, or TimeStamp) �now�_dtr; r r� �parse�floatr Z
fromtimestamp�utc_tzr, � TypeError)r �tr6 r6 r9 r� j s
zTimeStamp.__init__c C s$ t |t�r| j|jk S | j|k S d S )N)r; r, r )r �otherr6 r6 r9 �__lt__x s
zTimeStamp.__lt__c C s$ t |t�r| j|j S | j| S d S )N)r; r, r )r r% r6 r6 r9 �__add__~ s
zTimeStamp.__add__c C s. t |t�r | j|j7 _n| j|7 _| S )N)r; r, r )r r% r6 r6 r9 �__iadd__� s
zTimeStamp.__iadd__c C s$ t |t�r| j|j S | j| S d S )N)r; r, r )r r% r6 r6 r9 �__sub__� s
zTimeStamp.__sub__c C s. t |t�r | j|j8 _n| j|8 _| S )N)r; r, r )r r% r6 r6 r9 �__isub__� s
zTimeStamp.__isub__Fc C s$ |rt j j| j�S t j j| j�S d S )N)r r �local_tzr" )r r r6 r6 r9 r � s z
TimeStamp.nowc C s | j j| j�S )N)r Z
astimezoner+ )r r6 r6 r9 r � s zTimeStamp.localc C s | j | jdd�S )NF)r )r� � iso8601_fmt)r r6 r6 r9 �__str__� s zTimeStamp.__str__c C sB t j|| j�\ }}}}}}}} }
tj||||||d| j�| _| jS )Nr )r Zstrptimer, r r" r ) r rd r� r� r r r r r Zyeardayr r6 r6 r9 r � s zTimeStamp.parser c C s | j tj||||d�7 _ d S )N)r^ r_ r` ra )r r r )r r^ r_ r` ra r6 r6 r9 �add� s z
TimeStamp.addc C s | j � }|| jk rdS dS d S )NTF)r r )r r r6 r6 r9 � in_future� s
zTimeStamp.in_futurec C s | j � }|| jkrdS dS d S )NTF)r r )r r r6 r6 r9 �in_past� s
zTimeStamp.in_pastTc C s0 |d kr| j }|r | j� j|�S | jj|�S d S )N)�
locale_fmtr Zstrftimer )r Zfmtr r6 r6 r9 r� � s
zTimeStamp.format)N)F)r r r r )NT)r� r r r r" r r+ r, r1 r� r& r' r( r) r* r r r- r r. r/ r0 r� r6 r6 r6 r9 r, b s$
c @ sh e Zd ZdZdejjdejejffiZ ddd�Z
dd� Z ddd �Z dd d �Z
d
d� Zdd� Zdd� ZdS )r- al
A class which schedules attempts until one succeeds.
Intervals are expressed as floating point seconds.
The retry attempt will be scheduled in the future based on the
retry_interval which may be either a number of seconds or a
callable object returning the number of seconds. The callable
form of the retry_interval is useful when the interval should be
adjusted based on prior history or other external factors,
e.g. backing off the frequency of the retry attempts if initial
attempts fail.
The retry callback should return False if the attempt fails, in
which case it will be scheduled again in the future based on the
current value obtained from the retry_interval. If the retry
callback returns True it indicates the retry attempt succeeded and
no more attempts will be made.
Retry's are started with the start() method and continues until
the retry callback returns True or the stop() method is called. It
is always safe to call stop() even if a retry is not pending.
The retry callback, user_data and notify_interval may be specified
in either the class init() or in the start() method for convenience.
If notify_interval is set a 'pending_retry' signal will be emitted
every time the notification interval elapses, this provides a
countdown till the next retry attempt.
The signature of the retry callback is: callback(retry_obj, user_data)
The signature of the pending_retry signal handler is: callback(retry_obj, seconds_pending, user_data)
The signature of the retry interval function is: interval(retry_obj, user_data)
�
pending_retryNc C s: t j j| � || _|| _|| _d| _|| _d | _d | _d S )Nr ) r0 r� �callback�retry_interval� user_data�failed_attempts�notify_interval� trigger_time�
timeout_id)r r3 r4 r5 r7 r6 r6 r9 r� � s zRetry.__init__c C s | j d k r tj| j � d | _ d S )N)r9 ZGLibZ
source_remove)r r6 r6 r9 �stop� s
z
Retry.stopc C sF |d k r|| _ |d k r || _|d k r*|| _| j� d| _| jd� d S )Nr T)r4 r5 r7 r: r6 �_schedule_alarm)r r4 r5 r7 r6 r6 r9 �start s z Retry.startFc C sh t j � }|r|| j� | _| j| }| jrH| jd|| j� t| j|�}n|}tjt |d �| j
�| _ d S )Nr2 i� ) r �_get_retry_intervalr8 r7 �emitr5 �minr0 Z timeout_addrW �_alarm_callbackr9 )r Z new_retryr �seconds_pendingZ
alarm_timer6 r6 r9 r;
s
zRetry._schedule_alarmc C s6 d | _ tj� }| j| }|dkr*| j� n| j� dS )Ng{�G�zt?F)r9 r r8 �_attempt_retryr; )r r rA r6 r6 r9 r@ s
zRetry._alarm_callbackc C s4 | j | | j�r| j� n| jd7 _| jd� d S )NrU T)r3 r5 r: r6 r; )r r6 r6 r9 rB - s
zRetry._attempt_retryc C s" t tttf�r | j| | j�S | jS )N)r; Z
interval_typer4 r3 r4 r5 )r r6 r6 r9 r= 4 s zRetry._get_retry_interval)NN)NNN)F)r� r r r r0 Z SignalFlagsZRUN_LASTZ
TYPE_FLOATZ
TYPE_PYOBJECTZ __gsignals__r� r: r< r; r@ rB r= r6 r6 r6 r9 r- � s $
)NN)r� r� )r� r )r� )F)N)N)N)N)rZ
__future__r Z six.movesr �__all__r� r r Zpydbusr/ r� Z
gi.repositoryr0 r� r� r� Zshutilr� r� ri �textwrapr �typesrK � functoolsr2 r3 r4 Zsetroubleshoot.configr5 Zsetroubleshoot.errcodeZcmpr? r( r) r. Zwhichr� Z TextWrapperr� r r� rb Zhref_rer� rf r� r� rL rJ ZLOG_CRITr� ZLOG_INFOrN rG rM r$ r+ r* r r r r r r r r
r r r
r r r r r Zsepolicyr� r r r r� r� r r r r! r" r% r& r# r r� r r r r r r r' r Ztimezoner ZdaylightZaltzoner r r ZHOURZtzinfor r r, r- Z
type_registerr6 r6 r6 r9 �<module> s&
0
*
,
/
fq