File: //snap/core20/2669/usr/lib/python3/dist-packages/cloudinit/analyze/__pycache__/show.cpython-38.pyc
U
Ӈg,+ � @ s d dl Z d dlZd dlZd dlZd dlmZmZ d dlmZ dddddd d
d d d
dd� Z dZ
dZ dZ e dddfZ
dd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� ZG d'd(� d(�Zd)d*� Zd+d,� Zd-d.� Zd6d0d1�Z d2d3� Z d4d5� Z dS )7� N)�subp�util)� uses_systemd�deltaZ description�elapsed�
event_type�indent�level�name�origin�result� timestamp�
total_time) z%dz%Dz%Ez%ez%Iz%lz%nz%oz%rz%tz%TZ
successful�failureZ container���c C sP t �� D ]:\}}|| kr|dkr2| �|d| �} q| �|d| �} q| jf |�S )N)r r r
z
{%s:08.5f}z{%s})�
format_key�items�replace�format)�msg�event�i�j� r �8/usr/lib/python3/dist-packages/cloudinit/analyze/show.py�
format_record6 s r c C s | r| � d�S d S )Nr
��get�r r r r �
event_nameA s
r c C s | r| � d�S d S )Nr r r r r r r G s
c C s | rt | ��d�d S d S )N�/r )r �splitr r r r � event_parentM s r" c C s t | �d��S �Nr
)�floatr r r r r �event_timestampS s r% c C s t j �t| �t jj�S �N)�datetimeZ
fromtimestampr% �timezoneZutcr r r r �event_datetimeW s �r) c C s || � � S r& )Z
total_seconds)�t1�t2r r r �
delta_seconds] s r, c C s t t| �t|��S r& )r, r) )�start�finishr r r �event_durationa s r/ c C sH |� � }|�t||�t| t|��ddt|��d�d d d�� |S )N�|� r � z`->)r r r )�copy�updater/ r, r) r �count)�
start_timer- r. �recordr r r � event_recorde s ��r8 c C s d| S )NzTotal Time: %3.5f seconds
r )r r r r �total_time_recordr s r9 c @ s* e Zd ZdZd dd�Zdd� Zdd� ZdS )
�SystemctlReaderzQ
Class for dealing with all systemctl subp calls in a consistent manner.
Nc C sD d | _ t�d�dg| _|r&| j�|� | j�d|g� | �� | _d S )NZ systemctlZshowz-p)�epochr Zwhich�args�append�extendr )�self�propertyZ parameterr r r �__init__{ s zSystemctlReader.__init__c
C sZ z*t j | jdd�\}}|r |W S || _W dS tk
rT } z | W Y �S d}~X Y nX dS )z�
Make a subp call based on set args and handle errors by setting
failure code
:return: whether the subp call failed or not
T�ZcaptureN)r r< r; � Exception)r? �value�errZsystemctl_failr r r r � s zSystemctlReader.subpc C s2 | j rtd�| j ���| j�d�d }t|�d S )z{
If subp call succeeded, return the timestamp from subp as a float.
:return: timestamp as a float
zBSubprocess call to systemctl has failed, returning error code ({})�=r2 i@B )r � RuntimeErrorr r; r! r$ )r? r
r r r �parse_epoch_as_float� s ��z$SystemctlReader.parse_epoch_as_float)N)�__name__�
__module__� __qualname__�__doc__rA r rH r r r r r: v s
r: c C s2 t � r t� S t�� s(dt�� d �� kr.t� S tS )a)
Determine which init system a particular linux distro is using.
Each init system (systemd, etc) has a different way of
providing timestamps.
:return: timestamps of kernelboot, kernelendboot, and cloud-initstart
or TIMESTAMP_UNKNOWN if the timestamps cannot be retrieved.
Zgentoo�system)r � gather_timestamps_using_systemdr Z
is_FreeBSDZ system_info�lower� gather_timestamps_using_dmesg�TIMESTAMP_UNKNOWNr r r r �dist_check_timestamp� s
rR c C s� z�t j dgdd�\} }| d �� }|D ]n}|�d��d�dkr&|�d��� }|d �d �}t|�}tt�� �tt� � � }|| }t
|||f W S q&W n t k
r� Y nX t S )
a
Gather timestamps that corresponds to kernel begin initialization,
kernel finish initialization using dmesg as opposed to systemctl
:return: the two timestamps plus a dummy timestamp to keep consistency
with gather_timestamps_using_systemd
ZdmesgTrB r zUTF-8�userr r2 �])
r �
splitlines�decode�findr! �stripr$ �timer �uptime� SUCCESS_CODErC rQ ) �data�_Z
split_entriesr Zsplitup�strippedZuser_space_timestamp� kernel_start�
kernel_endr r r rP � s rP c
C s� t t�� �t t�� � } zBtd��� }tdd��� }| }t}t�� rHt}|| }|| }W n2 t k
r� } zt
|� t W Y �S d}~X Y nX || ||fS )z�
Gather timestamps that corresponds to kernel begin initialization,
kernel finish initialization. and cloud-init systemd unit activation
:return: the three timestamps
ZUserspaceTimestampMonotonicZ InactiveExitTimestampMonotoniczcloud-init-localN) r$ rY r rZ r: rH r[ Z is_container�CONTAINER_CODErC �printrQ )r_ Z delta_k_endZ
delta_ci_sZ base_timeZstatusr` Zcloudinit_sysd�er r r rN � s& � � rN �(%n) %d seconds in %I%Dc C s� t | dd� d�}g }d}d}i }g }g }tt|��D �]F} | | }
z| | d } W n tk
rj d} Y nX t|
�dk�r(|r�|
�d�d kr�|�t|�� |�|� g }d}d}|dkr�t|
�}||t |
�< t
|
�t
| �k�rt| �d
k�r&|�t |t ||
| ��� n |�d |
�d� � |�|
� q4q4|�
� } t
|
�t
| �k�rrt || |
�}
|�t d |
�d
� ||
�d�7 }q4|�| � q4|�t|�� |�|� |S )as
Take in raw events and create parent-child dependencies between events
in order to order events in chronological order.
:param events: JSONs from dump that represents events taken from logs
:param print_format: formatting to represent event, time stamp,
and time taken by the event in one line
:return: boot records ordered chronologically
c S s | d S r# r )�xr r r �<lambda> � z"generate_records.<locals>.<lambda>)�keyNg r2 r- r
z
init-localr. zStarting stage: %sz Finished stage: (%n) %d seconds�
r )�sorted�range�len�
IndexErrorr r r= r9 r) r" r r r8 �pop)�events� print_formatZ
sorted_eventsZrecordsr6 r Zstage_start_timeZ boot_recordsZ unprocessedrc r Znext_evtZprev_evtr7 r r r �generate_records s^
��
��
rq c C s t | |d�S )a<
A passthrough method that makes it easier to call generate_records()
:param events: JSONs from dump that represents events taken from logs
:param print_format: formatting to represent event, time stamp,
and time taken by the event in one line
:return: boot records ordered chronologically
)rp )rq )ro rp r r r � show_eventsK s
rr c C s^ | � � }|�� s,tj�d| j � t�d� zt�|�|fW S t k
rX d|f Y S X dS )z�
Takes in a log file, read it, and convert to json.
:param infile: The Log file to be read
:return: json version of logfile, raw file
zEmpty file %s
r2 N)
�readrX �sys�stderr�writer
�exit�json�loads�
ValueError)Zinfiler\ r r r �load_events_infileX s
r{ )rd ) r' rx rt rY Z cloudinitr r Zcloudinit.distrosr r r[ Z FAIL_CODEra rQ r r r r" r% r) r, r/ r8 r9 r: rR rP rN rq rr r{ r r r r �<module> sN �
5 # �
J