Google
Edit File: show.cpython-39.pyc
a '�Dg,+ � @ 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�delta� 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�failure� container���c C sT t �� D ]:\}}|| v r|dv r2| �|d| �} q| �|d| �} q| jf i |��S )N)r r r z {%s:08.5f}z{%s})� format_key�items�replace�format)�msg�event�i�j� r �:/usr/lib/python3.9/site-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 r1 c C sH |� � }|�t||�t| t|��ddt|��d�d d d�� |S )N�|� r" � z`->)r r r )�copy�updater1 r. r+ r! �count)� start_timer/ r0 �recordr r r � event_recorde s ��r: c C s d| S )NzTotal Time: %3.5f seconds r )r r r r �total_time_recordr s r; 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 �which�args�append�extendr )�self�propertyZ parameterr r r �__init__{ s zSystemctlReader.__init__c C sX z*t j | jdd�\}}|r |W S || _W dS tyR } z|W Y d}~S d}~0 0 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)rB �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 ({})�=r4 i@B )r � RuntimeErrorr r= r# r& )rB r r r r �parse_epoch_as_float� s ��z$SystemctlReader.parse_epoch_as_float)N)�__name__� __module__� __qualname__�__doc__rD r rK r r r r r< v s r< c C s2 t � r t� S t�� s(dt�� d �� v r.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 rU 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 y� Y n0 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 ZdmesgTrE r zUTF-8�userr r4 �]) r � splitlines�decode�findr# �stripr& �timer �uptime� SUCCESS_CODErF rT ) �data�_Z split_entriesr Zsplitup�strippedZuser_space_timestamp� kernel_start� kernel_endr r r rS � s rS c C s� t t�� �t t�� � } zBtd��� }tdd��� }| }t}t�� rHt}|| }|| }W n0 t y� } zt |� t W Y d}~S d}~0 0 || ||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& r\ r r] r< rK r^ Z is_container�CONTAINER_CODErF �printrT )rb Z delta_k_endZ delta_ci_sZ base_time�statusrc Zcloudinit_sysd�er r r rQ � s$ �� rQ �(%n) %d seconds in %I%Dc C s� t | dd� d�}g }d}d}i }g }g }tt|��D �]D} | | } z| | d } W n tyh d} Y n0 t| �dk�r&|r�| �d�d kr�|�t|�� |�|� g }d}d}|du r�t| �}||t | �< t | �t | �k�rt| �d k�r$|�t |t || | ��� n |�d | �d� � |�| � q4q4|� � } t | �t | �k�rpt || | �} |�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 r4 r/ r z init-localr0 zStarting stage: %sz Finished stage: (%n) %d seconds� r )�sorted�range�len� IndexErrorr r r@ r; r+ r$ r! r r: �pop)�events� print_formatZ sorted_eventsZrecordsr8 r Zstage_start_timeZ boot_recordsZ unprocessedrg r Znext_evtZprev_evtr9 r r r �generate_records s^ �� �� ru 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 )rt )ru )rs rt r r r � show_eventsK s rv c C s\ | � � }|�� s,tj�d| j � t�d� zt�|�|fW S t yV d|f Y S 0 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 r4 N) �readr[ �sys�stderr�writer �exit�json�loads� ValueError)Zinfiler_ r r r �load_events_infileX s r )rh ) r) r| rx r\ Z cloudinitr r Zcloudinit.distrosr r r^ Z FAIL_CODErd rT r r! r r$ r' r+ r. r1 r: r; r< rU rS rQ ru rv r r r r r �<module> sN � 5 # � J