U Ӈg,+ @sddlZddlZddlZddlZddlmZmZddlmZdddddd d d d d dd Z dZ dZ dZ e dddfZ ddZddZddZddZddZddZdd Zd!d"Zd#d$Zd%d&ZGd'd(d(Zd)d*Zd+d,Zd-d.Zd6d0d1Zd2d3Zd4d5ZdS)7N)subputil) uses_systemddeltaZ descriptionelapsed event_typeindentlevelnameoriginresult timestamp total_time) z%dz%Dz%Ez%ez%Iz%lz%nz%oz%rz%tz%TZ successfulfailureZ containercCsPtD]:\}}||kr|dkr2||d|}q||d|}q|jf|S)N)rrr z {%s:08.5f}z{%s}) format_keyitemsreplaceformat)msgeventijr8/usr/lib/python3/dist-packages/cloudinit/analyze/show.py format_record6s rcCs|r|dSdS)Nr getrrrr event_nameAs rcCs|r|dSdS)NrrrrrrrGs cCs|rt|ddSdS)N/r)rsplitrrrr event_parentMsr"cCst|dSNr )floatrrrrrevent_timestampSsr%cCstjt|tjjSN)datetimeZ fromtimestampr%timezoneZutcrrrrevent_datetimeWsr)cCs ||Sr&)Z total_seconds)t1t2rrr delta_seconds]sr,cCstt|t|Sr&)r,r))startfinishrrrevent_durationasr/c CsH|}|t||t|t|ddt|dddd|S)N| r z`->)rrr)copyupdater/r,r)rcount) start_timer-r.recordrrr event_recordes r8cCsd|S)NzTotal Time: %3.5f seconds r)rrrrtotal_time_recordrsr9c@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)r?valueerrZsystemctl_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 ({})=r2i@B)r RuntimeErrorrr;r!r$)r?r rrrparse_epoch_as_floats z$SystemctlReader.parse_epoch_as_float)N)__name__ __module__ __qualname____doc__rArrHrrrrr:vs 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 rRc 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 ZdmesgTrBrzUTF-8userrr2]) r splitlinesdecodefindr!stripr$timeruptime SUCCESS_CODErCrQ) data_Z split_entriesrZsplitupstrippedZuser_space_timestamp kernel_start kernel_endrrrrPs rPc Cstttt}zBtd}tdd}|}t}trHt}||}||}Wn2t k r}zt |t WYSd}~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-localN) r$rYrrZr:rHr[Z is_containerCONTAINER_CODErCprintrQ)r_Z delta_k_endZ delta_ci_sZ base_timeZstatusr`Zcloudinit_sysderrrrNs& rN(%n) %d seconds in %I%Dc Cst|ddd}g}d}d}i}g}g}tt|D]F} || } z|| d} Wntk rjd} YnXt| dkr(|r| dd kr|t|||g}d}d}|dkrt| }||t | <t | t | krt| d kr&|t |t || | n |d | d|| q4q4| } t | t | krrt || | } |t d | d || d7}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 cSs|dSr#r)xrrrz"generate_records..)keyNgr2r-r z init-localr.zStarting stage: %szFinished stage: (%n) %d seconds r)sortedrangelen IndexErrorrrr=r9r)r"rrr8pop)events print_formatZ sorted_eventsZrecordsr6rZstage_start_timeZ boot_recordsZ unprocessedrcrZnext_evtZprev_evtr7rrrgenerate_recordss^        rqcCs 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 )rp)rq)rorprrr show_eventsKs rrcCs^|}|s,tjd|jtdzt||fWSt k rXd|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 zEmpty file %s r2N) readrXsysstderrwriter exitjsonloads ValueError)Zinfiler\rrrload_events_infileXs r{)rd)r'rxrtrYZ cloudinitrrZcloudinit.distrosrrr[Z FAIL_CODErarQrrrr"r%r)r,r/r8r9r:rRrPrNrqrrr{rrrrsN    5# J