관리-도구
편집 파일: util.cpython-39.pyc
a U+eӈ � @ s� d dl mZ d dlmZ g d�Zd dlZd dlZd dlZd dlm Z d dl Z d dl m Z d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlT d dlZd dlmZ d d lmZm Z d d l m Z d dl T d d � Z d d� Z!dZ"d Z#dZ$e�%d��rdZ$ne�%d��r&dZ$dZ&e�'� Z(e�)d�Z*e�)d�Z+e�)d�Z,e�)d�Z-e�)d�Z.e�)d�Z/da0ej1a2ej3ej4ej1ej5ej6d�Z7dd � Z8d d � Z9d d � Z:d!d"� Z;d#d$� Z<d%d&� Z=d'd(� Z>d)d*� Z?dd+d,�Z@d-d.� ZAd�d1d2�ZBd�d3d4�ZCd�d6d7�ZDd8d9� ZEd:d;� ZFd<d=� ZGd>d?� ZHdeH_Id@dA� ZJdBdC� ZKdDdE� ZLi eL_MdFdG� ZNi eN_Mzd dHlOmPZP eP� ZQW n g ZQY n0 dIdJ� ZRdKdL� ZSdMdN� ZTdOdP� ZUd�dRdS�ZVdTdU� ZWdVdW� ZXdXdY� ZYdZd[� ZZd\d]� Z[d�d^d_�Z\d`da� Z]d�dbdc�Z^ddde� Z_d�dfdg�Z`dhdi� Zad�djdk�Zbdldm� Zcdndo� Zddpdq� Zedrds� Zfejgejh dt�Ziejj�rXejgejk dt�ZlneiZlelei Zme�gd �Znejgdudv�ZoG dwdx� dxejp�ZqG dydz� dzejp�ZrG d{d|� d|�ZsG d}d~� d~e j �Zte �uet� dS )�� )�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�is_standard_directory�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)�SystemMessageBus)�GObject)�*)� cmp_to_key)� FunctionType� MethodType)� get_configc C s | |k| |k S �N� ��x�yr8 r8 �7/usr/lib/python3.9/site-packages/setroubleshoot/util.py�<lambda>^ � r= c C s. z t | t�W S ty( t | t� Y S 0 d S r7 )� isinstanceZTypeType� NameError�type��objr8 r8 r< �is_typea s rD � �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 �t| d��� �atd u r"tjad S )N�level)� log_levels�getr6 �upper� log_level�syslog� LOG_WARNING)�sectionr8 r8 r< �log_init� s rS c C s t tjkrt�tj| � d S r7 )rO rP � LOG_DEBUG)�msgr8 r8 r< r% � s r% c C s* | � d�}|D ]}t|�rt�|� qd S )N� )�split�lenrP )ZtraceZ log_lines�liner8 r8 r< r, � s r, c C sz d }}| � 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)rW rX �intr) r% r* )�version�major�minor� componentsr8 r8 r< r+ � s r+ c C s� | d u r d S dd l }|�| �\}}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)�mathZmodfr] )Z elapsed_timerc ZfractionZwhole�days�hours�minutes�secondsr8 r8 r< r � s$ r c C s t �| �rdS dS d S �NTF)�hex_re�match��strr8 r8 r< r � s r c C sj | d u r d S t �| �}|r&|�d�}n@z.tjd dk rB| �d�}nt�| ��d�}W n | }Y n0 |S )Nr[ r rE �hexzutf-8)�audit_decode_re�search�group�sys� version_info�decode� bytearray�fromhex)rU rj Zdecodedr8 r8 r< r � s r c C sH |s| S | s|S i }| D ] }d||< q|D ] }d||< q*t |�� �}|S )z2return a list containing the unique members of a+bN)�list�keys)�a�b�d�i�mr8 r8 r< r � s r c s^ |d u r g }t |�}| | }|dkrZt� �rJ|�� fdd�t|�D �� n|�� g| � |S )Nr c s g | ] }� � �qS r8 r8 ��.0r: ��defaultr8 r< � <listcomp>� r> z"preextend_list.<locals>.<listcomp>)rX rD �extendr )Zrequested_lengthZ_listr� Z cur_lengthZdeltar8 r r< r � s r c s� t � tj�r� S t � ttf�r:dd�dd� � D �� d S t � t�rxt� �� �}|�� dd�� fdd�|D �� d S t � �S d S ) N�[� c S s g | ]}d t |� �qS )z%s�r r} r8 r8 r< r� r> zfmt_obj.<locals>.<listcomp>�]�{c s$ g | ] }d t |�t � | �f �qS )z%s=%sr� )r~ �keyrB r8 r< r� r> �}) r? �six� string_typesrv �tuple�join�dictrw �sortrl )rC rw r8 rB r< r s r � �P c C sv t | �|kr"| d|d � d }n| d|t | � }|rB|�� rN|| d S |t_d| t_|t_t�|�d S d S )Nr r[ r� rV )rX �isspace� text_wrapper�initial_indent�subsequent_indent�width�fill)�name�valueZ value_indentZ page_widthr� r8 r8 r< r s r c C s( d| }|t _|t _|t _t �| �d S )Nr� rV )r� r� r� r� r� )�sr� �indent�prefixr8 r8 r< r s r � c C sD |d u r d}|� � }d| }|t_|t_dt_| d t�|� d S )N� r� r� rV z )�stripr� r� r� r� r� )�titlerU r� Z indentStringr8 r8 r< r % s r c C s$ t �d| ��� }|d u r dS |S d S )Nr� r� )�fix_newline_re�subr� )rl Znew_strr8 r8 r< r 0 s r c C s | d u rdt d� d } t| �S )N�<ZUnknown�>)�_rl )�valr8 r8 r< r 8 s r c C s | d u rt | �S | �� S r7 )r �format)�dater8 r8 r< r > s r c C sL | du r dS t j�| �} | r(t j�| �s,dS tjdu rBtt� �t_| tjv S )z� Check whether given path is a standard directory. >>> is_standard_directory('/etc') True >>> is_standard_directory('/etc/systemd/') False >>> is_standard_directory('/usr/bin/cat') False NF)�os�path�normpath�isabsr �data�setr )r� r8 r8 r< r D s r c C s� g } zTt dkr.tjg d�dtjd��� �d�} t dkrVtjg d�dtjd��� �d�} W n> tjy� } z$t�tjd� t |j �� W Y d }~n d }~0 0 | S ) zH >>> get_standard_directories() # doctest: +ELLIPSIS [...'/bin'...] rF )rF z-qlZ filesystemT��universal_newlines�stderrrV rH )rG z-Lz base-filesz failed to get list from {}: {}N) r/ � subprocess� check_output�PIPE�rstriprW �CalledProcessErrorrP �LOG_ERRr� r� )Zlst�er8 r8 r< r b s $.r c C s& | d }| d }| d }d|||f S )z6Given an RPM header return the package NVR as a stringr� r^ �releasez%s-%s-%sr8 )Zhdrr� r^ r� r8 r8 r< r t s r c C s� | du r dS | t jv r t j| S d}zNtdkrJtjdd| gdtjd��� }tdkrptjddd | gdtjd��� }W n@ tjy� } z&t�tj d t| |j f � W Y d}~n d}~0 0 |t j| < |S ) z? >>> get_package_nvr_by_name("coreutils")[0:9] 'coreutils' NrF �-qTr� rH � dpkg-queryz(-f=${Package}-${Version}:${Architecture}z-Wz,failed to retrieve %s info for name '%s': %s) r �cacher/ r� r� r� r� r� rP r� r� )r� �nvrr� r8 r8 r< r } s �0 r c C s� | du r dS t j�| �s dS t j�| �} t j�| �s8dS | tjv rLtj| S d}z�tdkrvtj dd| gdtj d�� � }tdk�r<z tj dd| gtj d �� � }W nL tj y� } z2|jd kr�dtj| < W Y d}~W dS � W Y d}~n d}~0 0 |�d �}|D ]@}|�d ��r q�|jd d d�d jdd d�d }t|�} �q<q�W nB tj �y� } z&t�tjdt| |jf � W Y d}~n d}~0 0 |tj| < |S )zB >>> get_package_nvr_by_file_path("/bin/ls")[0:9] 'coreutils' NrF z-qfTr� rH r� z-S)r� r[ rV z diversion by z: )�maxsplitr z, z,failed to retrieve %s info for path '%s': %s)r� r� r� r� �existsr r� r/ r� r� r� r� rs r� � returncoderW � startswithr rP r� r� )r� r� �queryZcperY Z package_namer� r8 r8 r< r � s@ 0 r )�get_all_file_typesc C s6 | � d�}|d }|d }d�|d d� �}|||fS )N�-������)rW r� )r� ra r� r^ r� r8 r8 r< r � s r c C s� t du rt� t du rdS t �| d�}|du r2dS t|�}|du r||�d�d }d| d }t|�}|du r||d7 }t|�}|S )a� 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")[0:14] 'selinux-policy' >>> get_rpm_nvr_by_type("mysqld_log_t")[0:13] 'mysql-selinux' >>> get_rpm_nvr_by_type("spc_t")[0:17] 'container-selinux' N�/r� z /usr/share/selinux/packages/z.ppz.bz2)�module_type_cache�build_module_type_cacherM r rW )Z selinux_typer� �package� module_namer8 r8 r< r � s r c C s" zt | � W dS Y dS 0 d S rh �r] rk r8 r8 r< � __str_is_int s r� c C s t �� \} }| dkrdS t� }g }t�d�|���*}tdd� |D �dd� d�}W d � n1 sb0 Y |D ]�}t�d �||��D ]�\}}}d |v r�zfztj d �|�d d �} W n t d �|��} Y n0 | D ] } t � | �} | r�||| � d�< q�| � � W q� Y q�0 q�qp|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" >>> build_module_type_cache() r Nz"/var/lib/selinux/{}/active/modulesc S s$ g | ] }|� � rt|j�r|j�qS r8 )�is_dirr� r� r} r8 r8 r< r� 6 r> z+build_module_type_cache.<locals>.<listcomp>c S s t | �S r7 r� )r: r8 r8 r< r= 6 r> z)build_module_type_cache.<locals>.<lambda>�r� z%/var/lib/selinux/{}/active/modules/{}Zcilz{}/cilZrt)�moder[ )�selinuxZselinux_getpolicytyper� r� �scandirr� �sorted�walk�bz2�open�typedef_regexprj rp �closer� ) ZretvalZ policytypeZmodule_type_dictZ prioritiesZ module_store�dir�dirpath�dirnames� filenames�frY �resultr8 r8 r< r� ! s. 8 r� Fc C sL |r(t � }|�dd�}t|�t| ���S t�t| ��}ttt�|���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")[0:14] 'selinux-policy' >>> get_rpm_nvr_by_scontext("system_u:system_r:mysqld_log_t:s0")[0:13] 'mysql-selinux' >>> get_rpm_nvr_by_scontext("system_u:system_r:timedatex_t:s0", use_dbus=True)[0:14] 'selinux-policy' z*org.fedoraproject.SetroubleshootPrivilegedz+/org/fedoraproject/SetroubleshootPrivilegedN)r0 Z get_proxyrl r r� Z context_newr Zcontext_type_get)ZscontextZuse_dbusZbusZ remote_object�contextr8 r8 r< r T s �r c C sd | du r dS d}z0ddl }|jdddd| gdd��d d �d }W n t�tjd | � Y n0 |S ) a; Find a source package for `name` rpm >>> get_rpm_source_package("policycoreutils-python-utils") 'policycoreutils' >>> get_rpm_source_package("selinux-policy-targeted") 'selinux-policy' >>> get_rpm_source_package("selinux-policy-targeted-35.8-1.fc35.noarch") 'selinux-policy' Nr rF r� z--qfz %{SOURCERPM}T)r� r� r\ z"failed to retrieve rpm info for %s)r� r� �rsplitrP r� )r� �srcr� r8 r8 r< r w s (r c C s6 t �� } zt�| �}W n ty* Y d S 0 |j}|S r7 )r� �getuid�pwd�getpwuid�KeyError�pw_dir)�uidZpwZhome_dirr8 r8 r< r � s r c C s t �| �}|rdS dS d S rh )�name_at_domain_rero )Zaddressrj r8 r8 r< r" � s r" c C s t dd�}t�tj||| � d S )NZ helper_apps�web_browser_launcher)r6 r� �spawnl�P_NOWAIT)�urlr� r8 r8 r< r# � s r# c C s6 t | dd �}|r"|d }|d }n t}t|�}||fS )N�argsr r[ )�getattrZERR_SOCKET_ERRORZ get_strerror)r� r� �errno�strerrorr8 r8 r< r& � s r& c C s� d}t j�| �shzt| d�}|�� W n@ tyf } z(d}t�tjd| |jf � W Y d }~n d }~0 0 zt � | |� W nB t y� } z*d}t�tjd| ||jf � W Y d }~n d }~0 0 zbt |t �r�|}nt �|�d }|d u r�|}t |t �r�|}ndd l} | �|�d }t �| ||� W nb t �y� } zHd}dd l} t�tjd| t �|�d | �|�d |jf � W Y d }~n d }~0 0 |S ) NT�wFzcannot create file %s [%s]zcannot chmod %s to %o [%s]r\ r z cannot chown %s to %s:%s [%s])r� r� r� r� r� � ExceptionrP r� r� �chmod�OSErrorr? r] r� �getpwnam�grp�getgrnam�chownr� �getgrgid) �filepathr� �ownerrp r� r� r� r� �gidr� r8 r8 r< r' � s: .0 Fr' c C s< dd l }|�|�� �d d }| jj}td|||f ��d S )Nr r[ rE z=%s must be implemented in subclass %s or ancestor class of %s)�inspectZgetouterframesZ currentframe� __class__�__name__�NotImplementedError)rC r� �method�subclassr8 r8 r< r$ � s �r$ c C s� | d u rd} nt �dd| �} tdd�}g }t�tj�|| d ��D ]<}tj�|�}|dv r\qBtj�tj�|��d }|� |� qB|S ) Nr2 z.py$r� �plugins� plugin_dir�.py)z __init__.pyr ) �rer� r6 �globr� r� r� �basename�splitext�append)� filter_globr � plugin_names�p� plugin_namer8 r8 r< r � s r c C s | � � |� � S r7 )Z get_priorityr9 r8 r8 r< � sort_plugins� s r c C sz t dd�}tj�|�s&td| � g S tj�|�}g }t| �}td| � |}|tjvr�z.t j � ||d �}t j � |�}|j �|� W nB ty� } z*t�tjd|t|�f � g W Y d }~S d }~0 0 |D ]�} d|| f }zDt j � ||d | d �}t j � |�}|j �|� |�|�� � W q� t�yb } z&t�tjd | t|�f � W Y d }~q�d }~0 0 q�|jtt�d � |S ) Nr r z4plugin directory %s does not exist, no plugin loadedzload_plugins() names=%sz /__init__.pyz&failed to initialize plugins in %s: %sz%s.%sr� r z failed to load %s plugin: %sr� )r6 r� r� �isdirr% r r rq �modules� importlib�util�spec_from_file_location�module_from_spec�loader� exec_moduler� rP r� rl r Zpluginr� r3 r ) r r Z plugin_baser r r� �mod_spec�modr� r r8 r8 r< r � s8 2r c C s~ zt t��� d �� } W n8 zdd l}d�|�� �} W n d} Y n0 Y n0 t�� }|d }|d }d||f }| |fS )Nr r� �unknownr\ r� z%s %s) r� �redhat_release_path� readlinesr� �distror� Zlinux_distributionr� �uname)Z myplatformr r Zkernel_releaseZcpuZos_descr8 r8 r< r s r c C s@ | d u rt �� } zt�| �}W n ty2 Y d S 0 |d }|S �Nr )r� r� r� r� r� )r� Z pwd_entry�usernamer8 r8 r< r 2 s r c C sT zdd l } | �� }|W S tyN } z t�tjd| � W Y d }~d S d }~0 0 d S )Nr zcannot lookup hostname: %s)ZsocketZ gethostnamer� rP r� )ZSocket�hostnamer� r8 r8 r< r > s r c C s\ t j�| �r| S t j�| �}tdd��d�}|D ]&}t j�||�}t j�|�r0| S q0d S )NZ fix_commandZprog_search_path�:)r� r� r� r r6 rW r� r� )�progr � search_pathrz r� r8 r8 r< r H s r c C s2 t dd�}t�dd| �} | d }tj�||�}|S )NZdatabase� database_dirz\.xml$r� z _database.xml)r6 r r� r� r� r� )r� r% �filenamer� r8 r8 r< r! T s r! c C s t �d�}d}d}d}d}d}| �� } |�| �D ]�}|r0d}t|�d��}|�d�} | dur0| dkrp||d 7 }| d kr�||d 7 }| d kr�||d 7 }| dkr�||7 }| dkr�||7 }| dkr�||7 }| dkr0||7 }q0|�rtj||||d�} td| | f � | S t � 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 Tr[ r\ N�yearim �month� Zweek� �day�hour�minute�second�rd re rf rg z)parse_datetime_offset(%s) = time delta %sz$could not parse datetime offset (%s)) r �compile�lower�finditerr] rp �datetime� timedeltar% rP r� ) �textZdatetime_offset_re�foundrd re rf rg rj ZquantityZunitZtdr8 r8 r< r( ] sB r( )rg r[ )re c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) � LocalTimezonec C s | � |�rtS tS d S r7 )�_isdst� DSTOFFSET� STDOFFSET��self�dtr8 r8 r< � utcoffset� s zLocalTimezone.utcoffsetc C s | � |�rtS tS d S r7 )r8 �DSTDIFF�ZEROr; r8 r8 r< �dst� s zLocalTimezone.dstc C s t j| �|� S r7 )�time�tznamer8 r; r8 r8 r< rC � s zLocalTimezone.tznamec C sD |j |j|j|j|j|j|�� ddf }t�|�}t� |�}|j dkS )Nr r� ) r' r( r+ r, r- r. �weekdayrB �mktime� localtime�tm_isdst)r< r= �ttZstampr8 r8 r< r8 � s � zLocalTimezone._isdstN)r� � __module__� __qualname__r> rA rC r8 r8 r8 r8 r< r7 � s r7 c @ s( e Zd Zd Zdd� Zdd� Zdd� ZdS )�UTCc C s t �d�S r �r3 r4 r; r8 r8 r< r> � s z UTC.utcoffsetc C s dS )NrK r8 r; r8 r8 r< rC � s z UTC.tznamec C s t �d�S r rL r; r8 r8 r< rA � s zUTC.dstN)r� rI rJ �__doc__r> rC rA r8 r8 r8 r< rK � s rK 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 u r| j dd�| _nft|tj�r0| �|� nNt|t�rNtj�|| 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�floatr3 Z fromtimestamp�utc_tzr- � TypeError)r< �tr8 r8 r< �__init__� s zTimeStamp.__init__c C s$ t |t�r| j|jk S | j|k S d S r7 �r? r- rQ �r< �otherr8 r8 r< �__lt__� s zTimeStamp.__lt__c C s$ t |t�r| j|j S | j| S d S r7 rX rY r8 r8 r< �__add__� s zTimeStamp.__add__c C s. t |t�r | j|j7 _n| j|7 _| S r7 rX rY r8 r8 r< �__iadd__� s zTimeStamp.__iadd__c C s$ t |t�r| j|j S | j| S d S r7 rX rY r8 r8 r< �__sub__� s zTimeStamp.__sub__c C s. t |t�r | j|j8 _n| j|8 _| S r7 rX rY r8 r8 r< �__isub__� s zTimeStamp.__isub__Fc C s$ |rt j �| j�S t j �| j�S d S r7 )r3 rP �local_tzrT )r< rO r8 r8 r< rP � s z TimeStamp.nowc C s | j �| j�S r7 )rQ Z astimezoner` �r< r8 r8 r< rO � s zTimeStamp.localc C s | j | jdd�S )NFrN )r� � iso8601_fmtra r8 r8 r< �__str__� s zTimeStamp.__str__c C sB t �|| j�\ }}}}}}}} } t�||||||d| j�| _| jS r )rB �strptimerb r3 rT rQ ) r< rl r' r( r+ r, r- r. rD ZyeardayrA r8 r8 r< rR s ��zTimeStamp.parser c C s | j tj||||d�7 _ d S )Nr/ )rQ r3 r4 )r< rd re rf rg r8 r8 r< �add s �z TimeStamp.addc C s | � � }|| jk rdS dS d S rh �rP rQ �r< rP r8 r8 r< � in_future s zTimeStamp.in_futurec C s | � � }|| jkrdS dS d S rh rf rg r8 r8 r< �in_past s zTimeStamp.in_pastTc C s0 |d u r| j }|r | �� �|�S | j�|�S d S r7 )� locale_fmtrO �strftimerQ )r< ZfmtrO r8 r8 r< r� s zTimeStamp.format)N)F)r r r r )NT)r� rI rJ rK rT r7 r` rb rj rW r[ r\ r] r^ r_ rP rO rc rR re rh ri r� r8 r8 r8 r< r- � s$ r- 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 �| � || _|| _|| _d| _|| _d | _d | _d S r ) r1 rW �callback�retry_interval� user_data�failed_attempts�notify_interval� trigger_time� timeout_id)r< rm rn ro rq r8 r8 r< rW O s zRetry.__init__c C s | j d ur t�| j � d | _ d S r7 )rs ZGLibZ source_removera r8 r8 r< �stopY s z Retry.stopc C sF |d ur|| _ |d ur || _|d ur*|| _| �� d| _| �d� d S )Nr T)rn ro rq rt rp �_schedule_alarm)r< rn ro rq r8 r8 r< �start^ s z Retry.startFc C sh t � � }|r|| �� | _| j| }| jrH| �d|| j� t| j|�}n|}t�t |d �| j �| _ d S )Nrl i� ) rB �_get_retry_intervalrr rq �emitro �minr1 Z timeout_addr] �_alarm_callbackrs )r< Z new_retryrP �seconds_pendingZ alarm_timer8 r8 r< ru j s zRetry._schedule_alarmc C s6 d | _ t�� }| j| }|dkr*| �� n| �� dS )Ng{�G�zt?F)rs rB rr �_attempt_retryru )r< rP r{ r8 r8 r< rz v s zRetry._alarm_callbackc C s4 | � | | j�r| �� n| jd7 _| �d� d S )Nr[ T)rm ro rt rp ru ra r8 r8 r< r| � s zRetry._attempt_retryc C s" t tttf�r | �| | j�S | jS r7 )r? Z interval_typer5 r4 rn ro ra r8 r8 r< rw � s zRetry._get_retry_interval)NN)NNN)F)r� rI rJ rM r1 Z SignalFlagsZRUN_LASTZ TYPE_FLOATZ TYPE_PYOBJECTZ __gsignals__rW rt rv ru rz r| rw r8 r8 r8 r< r. % s %� r. )NN)r� r� )r� r )r� )F)N)N)N)N)vZ __future__r Z six.movesr �__all__r� r� r3 Zdasbus.connectionr0 r Z gi.repositoryr1 r r� r� r �shutilr� r� rq �textwraprB �typesrP � functoolsr3 r4 r5 Zsetroubleshoot.configr6 Zsetroubleshoot.errcode�cmprD r) r* r/ �whichr Z TextWrapperr� r0 r� ri Zhref_rer� rn r� r� rQ rO ZLOG_CRITr� ZLOG_INFOrT rL rS r% r, r+ 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( r4 �timezoner: �daylight�altzoner9 r? r@ ZHOURZtzinfor7 rK r- r. Z type_registerr8 r8 r8 r< �<module> s� 0 � ; 23 # * $ / fq