U Ld. @sddlZddlZddlZddlZddlmZmZddlmZdddddd d d d d dd Z d dde DZ dZ dZdZedddfZddZddZddZddZddZd d!Zd"d#Zd$d%Zd&d'Zd(d)ZGd*d+d+Zd,d-Zd.d/Zd0d1Zd:d4d5Zd6d7Z d8d9Z!dS);N)subputil) uses_systemddeltaZ descriptionelapsed event_typeindentlevelnameoriginresult timestamp total_time) z%dz%Dz%Ez%ez%Iz%lz%nz%oz%rz%tz%T cCs$g|]\}}d|dd|qS)z{0}: {1}%z%%)formatreplace).0kvr8/usr/lib/python3/dist-packages/cloudinit/analyze/show.py 1srZ successfulfailureZ containercCsPtD]:\}}||kr|dkr2||d|}q||d|}q|jf|S)N)rrr z {%s:08.5f}z{%s}) format_keyitemsrr)msgeventijrrr format_record9s r!cCs|r|dSdS)Nr getrrrr event_nameDs r%cCs|r|dSdS)Nrr"r$rrrrJs cCs|rt|ddSdS)N/r)r%splitr$rrr event_parentPsr(cCst|dSNr )floatr#r$rrrevent_timestampVsr+cCstjt|SN)datetimeZutcfromtimestampr+r$rrrevent_datetimeZsr.cCs ||Sr,)Z total_seconds)t1t2rrr delta_seconds^sr1cCstt|t|Sr,)r1r.)startfinishrrrevent_durationbsr4c CsH|}|t||t|t|ddt|dddd|S)N|rr&z`->)rrr)copyupdater4r1r.r%count) start_timer2r3recordrrr event_recordfs r<cCsd|S)NzTotal Time: %3.5f seconds r)rrrrtotal_time_recordssr=c@s*eZdZdZd ddZddZddZdS) SystemctlReaderzQ Class for dealing with all systemctl subp calls in a consistent manner. NcCsDd|_tddg|_|r&|j||jd|g||_dS)NZ systemctlZshowz-p)epochrZwhichargsappendextendr)selfpropertyZ parameterrrr__init__|s  zSystemctlReader.__init__c CsZz*tj|jdd\}}|r |WS||_WdStk rT}z |WYSd}~XYnXdS)z Make a subp call based on set args and handle errors by setting failure code :return: whether the subp call failed or not TZcaptureN)rr@r? Exception)rCvalueerrZsystemctl_failrrrrszSystemctlReader.subpcCs2|jrtd|j|jdd}t|dS)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 ({})=r6i@B)r RuntimeErrorrr?r'r*)rCr rrrparse_epoch_as_floats z$SystemctlReader.parse_epoch_as_float)N)__name__ __module__ __qualname____doc__rErrLrrrrr>ws r>cCs2tr tSts(dtdkr.tStS)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. Zgentoosystem)rgather_timestamps_using_systemdrZ is_FreeBSDZ system_infolowergather_timestamps_using_dmesgTIMESTAMP_UNKNOWNrrrrdist_check_timestamps rVc Csztjdgdd\}}|d}|D]n}|dddkr&|d}|dd }t|}tttt }||}t |||fWSq&Wnt k rYnXt 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 ZdmesgTrFrzUTF-8userrr6]) r splitlinesdecodefindr'stripr*timeruptime SUCCESS_CODErGrU) data_Z split_entriesrZsplitupstrippedZuser_space_timestamp kernel_start kernel_endrrrrTs rTc Cstttt}ztd}tdd}|}t}trtttt}zt d}|j }Wn2t k r}zt d||W5d}~XYnXt}||}||}Wn2tk r} zt| tWYSd} ~ XYnX||||fS)z Gather timestamps that corresponds to kernel begin initialization, kernel finish initialization. and cloud-init systemd unit activation :return: the three timestamps ZUserspaceTimestampMonotonicZInactiveExitTimestampMonotoniczcloud-init-localz/proc/1/cmdlinezBCould not determine container boot time from /proc/1/cmdline. ({})N)r*r]rr^r>rLr_Z is_container monotonicosstatst_atimeOSErrorrKrCONTAINER_CODErGprintrU) rcZ delta_k_endZ delta_ci_sZ base_timeZstatusZ file_statrIrdZcloudinit_sysderrrrRs>   rRF(%n) %d seconds in %I%Dc Cst|ddd}g}d}d}i} g} g} tdt|D]F} || } z|| d}Wntk rld}YnXt| dkr*|r| d d kr|t|| |g}d}d}|dkrt| }|| t | <t | t |krt|d kr(|t |t || |n |d | d | | q6q6| }t | t |krtt ||| }|t d |d||d7}q6| |q6|t|| || S)a2 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 blame_sort: whether to sort by timestamp or by time taken. :param print_format: formatting to represent event, time stamp, and time taken by the event in one line :param dump_files: whether to dump files into JSONs :param log_datafiles: whether or not to log events generated :return: boot records ordered chronologically cSs|dSr)r)xrrr$z"generate_records..)keyNgrr6r2r z init-localr3zStarting stage: %szFinished stage: (%n) %d seconds r)sortedrangelen IndexErrorrr#rAr=r.r(r%r!r<pop)eventsZ blame_sort print_formatZ dump_filesZ log_datafilesZ sorted_eventsZrecordsr:rZstage_start_timeZ boot_recordsZ unprocessedrlrZnext_evtZprev_evtr;rrrgenerate_recordss^        rzcCs 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 )ry)rz)rxryrrr show_events_s r{cCs:|}zt||fWStk r4d|fYSXdS)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 N)readjsonloads ValueError)Zinfiler`rrrload_events_infilels r)FrmFF)"r-r}rfr]Z cloudinitrrZcloudinit.distrosrrjoinrZformatting_helpr_Z FAIL_CODErjrUr!r%rr(r+r.r1r4r<r=r>rVrTrRrzr{rrrrrsZ    50 P