D7net
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
usr
/
libexec
/
kcare
/
python
/
kcarectl
/
__pycache__
/
Filename :
utils.cpython-36.pyc
back
Copy
3 �ӹh � @ s@ d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m Z ddl m Z ej d�Z dZed�Zed �Zed�Zd6d d �Zd7dd�Zd8dd�Zd9dd�Zdd� Zd:dd�Zdedfdd�Zd d � Zd d � Zd d!� Z d"d#� Z d$d%� Z d&d'� Z ed(d)� �Z d*d+� Z!d;d,d-�Z"d<d.d/�Z#d0d1� Z$d2d3� Z%d4d5� Z&dS )=� )�print_functionN)�datetime� )� constantsz^(\d+[.]\d+[-]\d+)� � � F�wc C s� | d }t jj|�}|r0t jj|� r0t j|� t||��&}|j|� |j� t j|j � � W d Q R X t j|t j �}zt j|� W d t j |� X t j || � d S )Nz.tmp) �os�path�dirname�exists�makedirs�open�write�flush�fsync�fileno�O_RDONLY�close�rename)�fname�content� ensure_dir�modeZ tmp_fnameZdname�fZ folder_fd� r �+/usr/libexec/kcare/python/kcarectl/utils.py� atomic_write" s r �utf-8c C s4 t | �tkr| S t | �tkr&| j|�S | j|�S d S )N)�type�ntype�btype�decode�encode)�data�encodingr r r �nstr9 s r' �latin1c C s t | �tkr| j|�} | S )N)r �utyper$ )r% r& r r r �bstrC s r* c C s t | �tkr| j|�} | S )N)r r" r# )r% r& r r r �ustrJ s r+ c s4 i � t j��� �fdd��}� |_� j|_�|_|S )Nc sH | t t|j� ��f}y� | S tk r0 Y nX �| |� }� |< |S )N)�tuple�sorted�items�KeyError)�args�kwargsZ cache_key�result)�cache�fnr r �innerU s zcached.<locals>.inner)� functools�wrapsr3 �clearZorig)r4 r5 r )r3 r4 r �cachedQ s r9 c sF �d krt j��d kr t j�� d kr*t j� i �� ����fdd�}|S )Nc s ����� �fdd�}|S )Nc s� �}xlt ��D ]`}y �| |�S tk rJ } z�|��s:� W Y d d }~X nX tj|� t|tjd� � tj�}qW y �| |�S tk r� } zt |d�� � W Y d d }~X nX d S )Nr �attempts) �range� Exception�time�sleep�min�random�uniformr �RETRY_MAX_DELAY�setattr)r0 r1 Zldelay�_�exZfinal_ex)�backoff� check_retry�count�delayr4 �stater r r5 q s z'retry.<locals>.decorator.<locals>.innerr )r4 r5 )rF rG rH rI rJ )r4 r � decoratorp s zretry.<locals>.decorator)r � RETRY_DELAY� RETRY_COUNT� RETRY_BACKOFF)rG rH rI rF rK r )rF rG rH rI rJ r �retrye s rO c C s� t jj| �sd S g }t j| �}|d k r2tj||�}xD|D ]<}t jj| |�}||krh|jt j|�j |f� |j dd� q8W xF||d � D ]6\}} t jj | �s�t jj | �r�t j | � q�tj| � q�W d S )NT)�reverse)r r r �listdir�fnmatch�filter�join�append�stat�st_mtime�sort�isfile�islink�remove�shutil�rmtree) Z directory� exclude_path�keep_n�patternr% r. �item� full_pathrD �entryr r r �clean_directory� s rd c C sN t tjjtjd�dd� t tjjtjd�dd� tjjtj�rJtjtj� d S )N�modulesr )r_ �patches) rd r r rT r � PATCH_CACHEr �CACHE_KEY_DUMP_PATH�unlinkr r r r �clear_all_cache� s rj c C s^ t jj|�}t jj|�s"t j|� t|d��(}tj| |� |j� t j |j � � W d Q R X d S )N�wb) r r r r r r r\ � copyfileobjr r r )�response�dstZ parent_dirr r r r � save_to_file� s ro c C s t j| �}|r|jd�p| S )Nr )� VERSION_RE�match�group)�versionrq r r r �strip_version_timestamp� s rt c C s0 | j d�\}}}|s$| j d�\}}}tj|d�S )N�T� z%Y-%m-%d)� partitionr �strptime)Zstr_rawZstr_date�seprD r r r �parse_response_date� s rz c G s0 ddl m} djdd� td |j� f| �D ��S )Nr )� ipv6_support�/c s s | ]}|j d �V qdS )r| N)�strip)�.0�itr r r � <genexpr>� s z'get_patch_server_url.<locals>.<genexpr>)r r{ rT rS �get_patch_server)�partsr{ r r r �get_patch_server_url� s r� c C s0 t jj| �sd S t| ��}|j� j� S Q R X d S )N)r r r r �readr} )�filenamer r r r � try_to_read� s r� c C s t tj�S )N)r� r rh r r r r � get_cache_key� s r� c C s. t jj| �s|S t| |�� }|j� S Q R X d S )N)r r r r r� )r r �defaultr r r r � _read_file� s r� c C s t | d|�}|S )N�r)r� )r r� r2 r r r � read_file� s r� c C s t | d|�}|S )N�rb)r� )r r� r2 r r r � read_file_bin� s r� c C sB i }| j � }x0|D ](}|r|jd�\}}}|r|j� ||< qW |S )N�:)� splitlinesrw r} )r% r2 Z data_lines�line�key� delimiter�valuer r r � data_as_dict� s r� c C s t ttj� ��S )N)�str�intr= r r r r � timestamp_str� s r� c G s t | � dS )za workaround to fix T201N)�print)�valuesr r r � print_wrapper� s r� )Fr )r )r( )r( )NNN)N)N)'� __future__r r rR r6 �rer\ r@ r= r r r �compilerp Z CACHE_ENTRIESr r! r" r) r r' r* r+ r9 rO rd rj ro rt rz r� r� r� r� r� r� r� r� r� r r r r �<module> sD $