o w7e. @s$ddlZddlZddlZddlZddlmZmZddlmZdddddd 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/Zd0d1Z 2 3 2 2d:d4d5Zd6d7Z d8d9Z!dS);N)subputil) uses_systemddelta 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 1s$r successfulfailure containercCsTtD]\}}||vr!|dvr||d|}q||d|}q|jdi|S)N)rrrz {%s:08.5f}z{%s}r) format_keyitemsrr)msgeventijrrr format_record9sr$cC|r|dSdS)Nr getr!rrr event_nameD r)cCr%)Nrr&r(rrrrJr*cCs|r t|ddSdS)N/r)r)splitr(rrr event_parentPsr-cCst|dSNr)floatr'r(rrrevent_timestampVsr0cCstjt|SN)datetimeutcfromtimestampr0r(rrrevent_datetimeZsr4cCs ||Sr1) total_seconds)t1t2rrr delta_seconds^s r8cCstt|t|Sr1)r8r4)startfinishrrrevent_durationbsr;c CsH|}|t||t|t|ddt|dddd|S)N|rr+z`->)rrr )copyupdater;r8r4r)count) start_timer9r:recordrrr event_recordfs rCcCsd|S)NzTotal Time: %3.5f seconds r)rrrrtotal_time_recordssrDc@s*eZdZdZd ddZddZddZdS) SystemctlReaderzQ Class for dealing with all systemctl subp calls in a consistent manner. NcCsDd|_tddg|_|r|j||jd|g||_dS)N systemctlshowz-p)epochrwhichargsappendextendr)selfproperty parameterrrr__init__|s  zSystemctlReader.__init__c CsTztj|jdd\}}|r|WS||_WdSty)}z|WYd}~Sd}~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)rrJrH Exception)rMvalueerrsystemctl_failrrrrszSystemctlReader.subpcCs2|jr td|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 ({})=r=i@B)r RuntimeErrorrrHr,r/)rMrrrrparse_epoch_as_floats  z$SystemctlReader.parse_epoch_as_floatr1)__name__ __module__ __qualname____doc__rPrrYrrrrrEws   rEcCs2trtStsdtdvrtStS)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_UNKNOWNrrrrdist_check_timestamps  rfc CszMtjdgdd\}}|d}|D]7}|dddkrJ|d}|dd }t|}tttt }||}t |||fWSqWt St yWYt Sw) 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 dmesgTrQrzUTF-8userrr=]) r splitlinesdecodefindr,stripr/timeruptime SUCCESS_CODErSre) data_ split_entriesr"splitupstrippeduser_space_timestamp kernel_start kernel_endrrrrds$  rdc Cstttt}zLtd}tdd}|}t}trOtttt}z t d}|j }Wnt yL}zt d||d}~wwt}||}||}Wntyp} z t| tWYd} ~ Sd} ~ ww||||fS)z Gather timestamps that corresponds to kernel begin initialization, kernel finish initialization. and cloud-init systemd unit activation :return: the three timestamps UserspaceTimestampMonotonicInactiveExitTimestampMonotoniczcloud-init-localz/proc/1/cmdlinezBCould not determine container boot time from /proc/1/cmdline. ({})N)r/rnrrorErYrp is_container monotonicosstatst_atimeOSErrorrXrCONTAINER_CODErSprintre) rw delta_k_end delta_ci_s base_timestatus file_statrUrxcloudinit_sysderrrr`sJ    r`F(%n) %d seconds in %I%Dc Cst|ddd}g}d}d}i} g} g} tdt|D]} || } z|| d}Wn ty4d}Ynwt| dkr|rV| d d krV|t|| |g}d}d}|durdt| }|| t | <t | t |krt|d kr~|t |t || |q|d | d | | q| }t | t |krt ||| }|t d |d||d7}q| |q|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$sz"generate_records..)keyNgrr=r9r z init-localr:zStarting stage: %szFinished stage: (%n) %d seconds r)sortedrangelen IndexErrorrr'rKrDr4r-r)r$rCpop)events blame_sort print_format dump_files log_datafiles sorted_eventsrecordsrArstage_start_time boot_records unprocessedrr!next_evtprev_evtrBrrrgenerate_recordssb          rcCs 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)rrrrr show_events_s rcCs4|}zt||fWStyd|fYSw)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)infilerqrrrload_events_infilels   r)FrFF)"r2rr}rn cloudinitrrcloudinit.distrosrrjoinrformatting_helprp FAIL_CODErrer$r)rr-r0r4r8r;rCrDrErfrdr`rrrrrrrs\    50 P