/
usr
/
lib64
/
python3.9
/
site-packages
/
ntp
/
__pycache__
/
Upload File
HOME
a \��d�# � @ sn d Z ddlmZmZ ddlZddlZddlZddlZddlZddl Z ddl Z G dd� d�Z dd� Z dd � Z dS ) zq statfiles.py - class for digesting and plotting NTP logfiles Requires gnuplot and liberation fonts installed. � )�print_function�divisionNc @ s� e Zd ZdZdZdZi ZdZdZdZ dZ e dd� �Z e dd � �Z e d d � �Ze d d � �Zddd�Zdd� Zdd� Zdd� Zdd� Zdd� ZdS )�NTPStatsz*Gather statistics for a specified NTP sitei�Q i�: N� c C s� g }| D ]�}z$|� � }t|d �}t|d �}W n tyF Y qY n0 tj| | d }|| krn|krn qt|d �|d< t|�|d< |�|� q|S )z�Extract first two fields, MJD and seconds past midnight. convert timestamp (MJD & seconds past midnight) to Unix time Replace MJD+second with Unix time.r � l �@" �� )�split�int�float� ValueErrorr � SecondsInDay�str�append) �lines� starttime�endtime�lines1�liner Zmjd�second�time� r �3/usr/lib64/python3.9/site-packages/ntp/statfiles.py�unixize s zNTPStats.unixizec C s t | �� d �S )z"get Unix time from converted line.r )r r )r r r r � timestamp9 s zNTPStats.timestampc C s� i }t |�}d|krFd|kr&|d }nd}| D ]}||dt|� < q.nD| D ]>}|dkrh||d |d< qJ|t||d � |dt|� < qJ|S )zwReturn given percentiles of a given row in a given set of entries. assuming values are already split and sortedr r �p�d Zp100)�lenr r )�percents�values�ret�length�value�percr r r � percentiles> s "zNTPStats.percentilesc C sd | d � � r`| �d�r4| �d�\}}}}d||f S zt�| �\}}}|W S tjy^ Y n0 | S )z,Produce appropriate label for an IP address.r z127.127.�.zREFCLOCK(type=%s,unit=%s))�isdigit� startswithr �socketZ gethostbyaddrZherror)�key�_Z clock_typeZunit�hostnamer r r �ip_labelV s zNTPStats.ip_labelc C s |du rt j}|| _|du r:|du r:tt�� �}|| }n2|du rT|durT|| }n|durl|du rl|| }|| _|| _|p�tj� |�| _ d| j kr�t � � | _ tj� |�s�tj�d| � td��g | _g | _g | _g | _g | _g | _dD ](}| �||�}| �||�}t| ||� q�dS )z.Grab content of logfiles, sorted by timestamp.NZntpstatsz%ntpviz: ERROR: %s is not a directory r )� clockstats� peerstats� loopstats�rawstats�temps�gpsd)r � DefaultPeriod�periodr r r r �os�path�basename�sitenamer' Zgetfqdn�isdir�sys�stderr�write� SystemExitr, r- r. r/ r0 r1 �_NTPStats__load_stem�_NTPStats__process_stem�setattr) �self�statsdirr7 r3 r r �stemr Z processedr r r �__init__m s< � zNTPStats.__init__c C s� g }z�t j�||�}|dkr,|dkr,|d7 }t�|d �D ]J}| jt j�|�krRq:|�d�rr|t�|d�� � 7 }q:|t|d�� � 7 }q:W n" t y� t j � d| � Y n0 |S ) Nr0 r1 r$ �*�gzZrt�rz#ntpviz: WARNING: could not read %s )r4 r5 �join�globr �getmtime�endswith�gzip�open� readlines�IOErrorr9 r: r; )r@ rA rB r �patternZlogpartr r r Z __load_stem� s � zNTPStats.__load_stemc C s� g }|dks|dkr�|D ]|}|� � }dt|�kr2qzt|d �}W n tyX Y qY n0 | j| krr| jkrn q|�dt|d �� |�|� qnt � || j| j�}|� � |S )Nr0 r1 � r r ) r r r r r r �insertr r r r �sort)r@ rB r r r r Z time_floatr r r Z__process_stem� s zNTPStats.__process_stemc C sb | j r | j S | jD ]H}z0|d }|| j vr4g | j |< | j | �|� W q tyX Y q0 q| j S )zoReturn a dictionary mapping peerstats IPs to entry subsets. This is very expensive, so cache the result� )�peermapr- r � IndexError)r@ �rowZ ip_addressr r r � peersplit� s zNTPStats.peersplitc C sR i }| j D ]B}z*|d }||vr(g ||< || �|� W q tyJ Y q 0 q |S )z9Return a dictionary mapping gps sources to entry subsets.rS )r1 r rU )r@ ZgpsmaprV �sourcer r r �gpssplit� s zNTPStats.gpssplitc C sR i }| j D ]B}z*|d }||vr(g ||< || �|� W q tyJ Y q 0 q |S )zAReturn a dictionary mapping temperature sources to entry subsets.rS )r0 r rU )r@ ZtempsmaprV rX r r r � tempssplit� s zNTPStats.tempssplit)NNNN)�__name__� __module__� __qualname__�__doc__r r2 rT r3 r r r7 � staticmethodr r r# r+ rC r= r> rW rY rZ r r r r r s0 � ) r c C s* t | ��� rt| �S t�| d�}t�|�S )zEAccept timestamps in ISO 8661 format or numeric POSIX time. UTC only.�%Y-%m-%dT%H:%M:%S)r r% r r �strptime�calendarZtimegm)Z time_stringZ time_structr r r � iso_to_posix� s rc c C s t �dt �| ��S )z&ISO 8601 string in UTC from Unix time.r` )r �strftime�gmtime)Z unix_timer r r � posix_to_iso s rf )r^ Z __future__r r rb rH rK r4 r' r9 r r rc rf r r r r �<module> s d