/usr/lib/python3/dist-packages/cloudinit/analyze/__pycache__
Edit: /usr/lib/python3/dist-packages/cloudinit/analyze/__pycache__/show.cpython-310.pyc (9377B)
o
th*7 @ sJ d dl Z d dlZd dlZd dlZd dlmZmZmZmZm Z m
Z
m Z m Z d dl
mZmZ d dlmZ ddddd d
d d d
ddd ZdZdZdZedddfZeZdededefddZde e de e fddZde e de e fd dZde e de e fd d Z dede fd d Z dede j fd!d"Z d#e j d$e j de fd%d&Z d'ed(ede fd)d*Z!d+e j d'ed(edefd,d-Z"de defd.d/Z#G d0d1 d1Z$de
ee e e f fd2d3Z%de
ee e e f fd4d5Z&de
ee e e f fd6d7Z' 8dBd9ee d:edeee fd;d<Z(d9ee d:edeee fd=d>Z)d?ede
e e ef fd@dAZ*dS )C N)IOAnyDictListOptionalTupleUnioncast)subputil) uses_systemddelta descriptionelapsed
event_typeindentlevelnameoriginresult timestamp
total_time) z%dz%Dz%Ez%ez%Iz%lz%nz%oz%rz%tz%T
successfulfailure containermsgeventreturnc C sT t D ] \}}|| v r!|dv r| |d| } q| |d| } q| jdi |S )N)r
r r z
{%s:08.5f}z{%s} )
format_keyitemsreplaceformat)r r ijr r 8/usr/lib/python3/dist-packages/cloudinit/analyze/show.py
format_record9 s r' c C | r| dS d S )Nr getr r r r&
event_nameD
r, c C r( )Nr r) r+ r r r& r J r- c C s t | }|r
|dd S d S )N/r )r, split)r r r r r& event_parentP s r0 c C s" | d}|d u r
tdt|S )Nr z Event is missing a 'timestamp')r*
ValueErrorfloat)r tsr r r& event_timestampW s
r4 c C s t j t| t jjS N)datetime
fromtimestampr4 timezoneutcr+ r r r& event_datetime^ s r: t1t2c C s || S r5 )
total_seconds)r; r< r r r&
delta_secondsd s r> startfinishc C s t t| t|S r5 )r> r: )r? r@ r r r& event_durationh s rA
start_timec C sX | }t|}d}|r|d|dd d 7 }|t||t| t||d |S )N| r. z`->)r
r r )copyr, countupdaterA r> r: )rB r? r@ recordr r r r r& event_recordl s rJ c C s d| S )NzTotal Time: %3.5f seconds
r )r r r r& total_time_record s rK c @ sP e Zd ZdZd dedee fddZdeeeef fdd Z de
fd
d Z dS )
SystemctlReaderzQ
Class for dealing with all systemctl subp calls in a consistent manner.
Nproperty parameterc C sF d | _ tddg| _|r| j| | jd|dg | | _d S )N systemctlshowz-pz--timestamp=us+utc)stdoutr
whichargsappendextend_subpr )selfrM rN r r r& __init__ s zSystemctlReader.__init__r c
C sT zt j | jdd\}}|r|W S || _W dS ty) } z|W Y d}~S d}~ww )z
Make a subp call based on set args and handle errors by setting
failure code
:return: whether the subp call failed or not
TcaptureN)r
rS rQ Exception)rW valueerrsystemctl_failr r r& rV s zSystemctlReader._subpc C sv | j r td| j | jdu rtd| jdd }| r*t|d }|S tj |dj
tj j 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 ({})Nz.stdout of subprocess call to systemctl is None=rE i@B z%a %Y-%m-%d %H:%M:%S.%f %Z)tzinfo)r RuntimeErrorr# rQ r/ strip isnumericr2 r6 strptimer" r8 r9 r )rW valr r r r& convert_val_to_float s&
z$SystemctlReader.convert_val_to_floatr5 ) __name__
__module__ __qualname____doc__strr rX r r[ rV r2 rf r r r r& rL s
rL c C s2 t rt S t sdt d v rt 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.
gentoosystem)r gather_timestamps_using_systemdr
is_FreeBSD system_infolower gather_timestamps_using_dmesgTIMESTAMP_UNKNOWNr r r r& dist_check_timestamp s
rt c C s zMt j dgdd\} }| d }|D ]7}|dddkrJ|d }|d d }t|}tt tt }|| }t
|||f W S qW t S t yW Y t S w )
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
dmesgTrY r zUTF-8userr rE ])
r
splitlinesdecodefindr/ rb r2 timer uptime SUCCESS_CODEr[ rs ) data_
split_entriesr$ splitupstrippeduser_space_timestamp kernel_start
kernel_endr r r& rr s$ rr c
C s z0t rtd } td }n td } td }td | }tdd | }W n tyH } z t| tW Y d}~S d}~ww t rOtnt}|| | | | | fS )z
Gather timestamps that corresponds to kernel begin initialization,
kernel finish initialization. and cloud-init systemd unit activation
:return: the three timesread_propertystamps
UserspaceTimestampUserspaceTimestampMonotonicKernelTimestampKernelTimestampMonotonic InactiveExitTimestampMonotoniczcloud-init-localN) r is_containerrL rf r[ printrs CONTAINER_CODEr} )r monotonic_offsetr cloudinit_sysdestatusr r r& rn s^ rn (%n) %d seconds in %I%Devents print_formatc C s t | dd d}g }d}d}i }g }g }tt|D ]} | | }
z| | d } W n ty3 d} Y nw t|
dkr|rU|
dd krU|t| || g }d}d}|du rct|
}||t |
< t
|
t
| krt| d
krt t | } |t
|t||
| q|d |
d ||
q| } t
|
t
| kr|rt|| |
}
|t
d |
d
||
dpd7 }q|| q|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 )Nr r )xr r r&
W s z"generate_records..)keyNg rE r? r z
init-localr@ zStarting stage: %sz Finished stage: (%n) %d seconds
r
)sortedrangelen
IndexErrorr r* rT rK r: r0 r, r r r' rJ pop)r r
sorted_eventsrecordsrB r stage_start_time boot_records unprocessedr r next_evtprev_evtrI r r r& generate_recordsH sl
r c C s t | |dS )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
)r )r )r r r r r& show_events s
r infilec C sX | }| stjd| j td zt||fW S t y+ d|f Y S w )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
rE N)
readrb sysstderrwriter exitjsonloadsr1 )r r~ r r r& load_events_infile s
r )r )+r6 r r r{ typingr r r r r r r r cloudinitr
r cloudinit.distrosr r r} FAIL_CODEr rs Eventrk r' r, r r0 r2 r4 r: r> rA rJ rK rL rt rr rn r r r r r r r& sp (
U ;
"P"