쑛h1 ddlZddlZddlZddlZddlmZmZddlmZdddddd d d d d dd Z dZ dZ dZ e dddfZ dZdZdZdZdZdZdZdZdZdZGddZd Zd!Zd"Z d&d#Zd$Zd%Zy)'N)subputil) uses_systemddelta descriptionelapsed event_typeindentlevelnameoriginresult timestamp total_time) z%dz%Dz%Ez%ez%Iz%lz%nz%oz%rz%tz%T successfulfailure containerctjD]9\}}||vs |dvr|j|d|z}%|j|d|z};|jdi|S)N)rrrz {%s:08.5f}z{%s}) format_keyitemsreplaceformat)msgeventijs 8/usr/lib/python3/dist-packages/cloudinit/analyze/show.py format_recordr 6sm  "11 855kk!\A%56kk!VaZ0 1 3::  c*|r|jdSy)Nr getrs r event_namer&As yy  r!c*|r|jdSy)Nr r#r%s rr r Gs yy&& r!cB|rt|jddSy)N/r)r&splitr%s r event_parentr+Ms# % &&s+A.. r!c6t|jdSNr)floatr$r%s revent_timestampr/Ss ;' ((r!ctjjt|tjjSN)datetime fromtimestampr/timezoneutcr%s revent_datetimer6Ws1    * * 1 1 5 5 r!c(||z jSr1) total_seconds)t1t2s r delta_secondsr;]s G " " $$r!c>tt|t|Sr1)r;r6)startfinishs revent_durationr?as .v0F GGr!c |j}|jt||t|t |ddt |j ddz zzdzd|S)N| r)z`->)rrr )copyupdater?r;r6r&count) start_timer=r>records r event_recordrIese [[]F MM#E62$Z1FGC:e#4#:#:3#?!#CDDuL  Mr!c d|zS)NzTotal Time: %3.5f seconds r)rs rtotal_time_recordrKrs (: 55r!c$eZdZdZddZdZdZy)SystemctlReaderzQ Class for dealing with all systemctl subp calls in a consistent manner. Ncd|_tjddg|_|r|jj ||jj d|dg|j|_y)N systemctlshowz-pz--timestamp=us+utc)stdoutrwhichargsappendextendr)selfproperty parameters r__init__zSystemctlReader.__init__{s^ ZZ ,f5  II  Y ' $*>?@ yy{ r!c tj|jd\}}|r|S||_y#t$r }|cYd}~Sd}~wwxYw)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)rrSrQ Exception)rVvalueerrsystemctl_fails rrzSystemctlReader.subpsG "499d;JE3 DK "! ! "s'22 AAAAc|jr$tdj|j|jj ddj }|j rt|dz }|Stjj|djtjjj}|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 ({})=rCi@Bz%a %Y-%m-%d %H:%M:%S.%f %Z)tzinfo)r RuntimeErrorrrQr*strip isnumericr.r2strptimerr4r5r)rVvalrs rconvert_val_to_floatz$SystemctlReader.convert_val_to_floats <<,,2F4<<,@  kk$Q'--/ ==?c W,I !!**30LM 1 1 5 56  r!r1)__name__ __module__ __qualname____doc__rYrrirr!rrMrMvs#"" #r!rMctr tStjs'dtjdj vr t StS)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)rgather_timestamps_using_systemdr is_FreeBSD system_infolowergather_timestamps_using_dmesgTIMESTAMP_UNKNOWNrr!rdist_check_timestamprwsM~.00 H(8(8(:8(D(J(J(LL,.. r!c tjdgd\}}|dj}|D]}|jdjddk7s'|jdj }|dj d }t |}t tjt tjz }||z}t|||fcS tS#t$rYtSwxYw) 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 dmesgTr[rzUTF-8userrrC]) r splitlinesdecodefindr*rer.timeruptime SUCCESS_CODEr]rv) data_ split_entriesrsplitupstrippeduser_space_timestamp kernel_start kernel_ends rrurus ))WIt4aQ**,  JAxx %%f-3((7+113"1:++C0(-X$$TYY[1E$++-4HH ),@@ $\:zII J"     sAC+B C+#C++ C<;C<c tjr3tdj}tdj}n2tdj}tdj}tdj|z }tddj|z }tjrtnt}||||z||zfS#t$r}t |t cYd}~Sd}~wwxYw)z Gather timestamps that corresponds to kernel begin initialization, kernel finish initialization. and cloud-init systemd unit activation :return: the three timesread_propertystamps UserspaceTimestampUserspaceTimestampMonotonicKernelTimestampKernelTimestampMonotonicInactiveExitTimestampMonotoniczcloud-init-localN) r is_containerrMrir]printrvCONTAINER_CODEr)rmonotonic_offsetrcloudinit_sysdestatuss rrqrqs!&!    +$""$  /- ""$ +!""$  /* ""$  - ""$   02D ""$   $002^ F z!~%   ! a  !sB2C D)C?9D?Dc t|d}g}d}d}i}g}g}tt|D]}} || } || dz} t | dk(r|rE| j ddk(r1|j t||j |g}d}d}|t| }||t| <t| t| k(r6t | d k(s|j t|t|| | |j d | j dz|j | |j} t| t| k(rAt|| | } |j td | d z|| j d z }m|j | |j t||j ||S#t$rd} YwxYw)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 |dSr-r)xs rz"generate_records..?s ;r!)keyNgrCr=r z init-localr>zStarting stage: %szFinished stage: (%n) %d seconds r)sortedrangelen IndexErrorr r$rTrKr6r+r&r rIpop)events print_format sorted_eventsrecordsrGrstage_start_time boot_records unprocessedrrnext_evtprev_evtrHs rgenerate_recordsr0s6'?@MGJJLK 3}% &,-q  a!e}H e  '599V, <0<=##G,!  !+E2 8B e!45% Jx$88h'83NN%((UHE3eii6GGH""5)"(H% Jx$88%j(EB!"CVLfjj11 ""8,Y,-\ NN$Z01 Y H sG G,+G,ct||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 )r)r)rrs r show_eventsrzs F >>r!c|j}|jsAtjj d|j ztj d tj||fS#t$rd|fcYSwxYw)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 rCN) readresysstderrwriter exitjsonloads ValueError)infilers rload_events_infilersq ;;=D ::< *V[[89  zz$%% Tzs#A:: B  B )z(%n) %d seconds in %I%D)r2rrr cloudinitrrcloudinit.distrosrrr FAIL_CODErrvr r&r r+r/r6r;r?rIrKrMrwrurqrrrrr!rrs *,               B+   ) %H 6IIX,>6v+GT ?r!