"T`j2@sddlZddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddddd d d d d dddddddddddddi Z dj dde j DZdZdZd ZedGdHdIfZd"d#Zd$d%Zd&d'Zd(d Zd)d*Zd+d,Zd-d.Zd/d0Zd1d2Zd3d4Zd5d6ZGd7d8d8eZd9d:Z d;d<Z!d=d>Z"d?d@d?d?dAdBZ#dCdDZ$dEdFZ%dS)JN)subp)util) uses_systemdz%ddeltaz%DZ descriptionz%Eelapsedz%e event_typez%Iindentz%llevelz%nnamez%ooriginz%rresultz%t timestampz%T total_time cCs4g|]*\}}dj|jdd|qS)z{0}: {1}%z%%)formatreplace).0kvr8/usr/lib/python3/dist-packages/cloudinit/analyze/show.py 3s rZ successfulfailureZ containercCsqxatjD]S\}}||kr |dkrJ|j|d|}q |j|d|}q W|j|S)Nrrr z {%s:08.5f}z{%s})rzelapsedz timestamp) format_keyitemsrr)msgeventijrrr format_record;s   r!cCstdd|jD}|d}g}xc|D][}|d}tjj|}tj|djd}tj |||j |q6W|S)Ncss-|]#\}}|dkr||fVqdS)contentN)zcontentr)rrrrrr Gsz#dump_event_files..filespathr"ascii) dictrosr%basenamebase64Z b64decodedecoderZ write_fileappend)rr"r$ZsavedffnameZfn_localZfcontentrrrdump_event_filesFs   r/cCs|r|jdSdS)Nr )get)rrrr event_nameTs r1cCs|r|jdSdS)Nr)r0)rrrrrZs cCs!|rt|jddSdS)N/r)r1split)rrrr event_parent`sr4cCst|jdS)Nr )floatr0)rrrrevent_timestampfsr6cCstjjt|S)N)datetimeZutcfromtimestampr6)rrrrevent_datetimejsr8cCs||jS)N)Z total_seconds)Zt1Zt2rrr delta_secondsnsr9cCstt|t|S)N)r9r8)startfinishrrrevent_durationrsr<c Csf|j}|jdt||dt|t|dddt|jdddi|S) Nrrr|rr2rz`->)copyupdater<r9r8r1count) start_timer:r;recordrrr event_recordvs  ,rCcCsd|S)NzTotal Time: %3.5f seconds r)rrrrtotal_time_recordsrDc@s=eZdZdZdddZddZddZdS) SystemctlReaderzQ Class for dealing with all systemctl subp calls in a consistent manner. NcCsWd|_ddg|_|r.|jj||jjd|g|j|_dS)Nz/bin/systemctlZshowz-p)epochargsr,extendrr)selfpropertyZ parameterrrr__init__s  zSystemctlReader.__init__cCsiy9tj|jdd\}}|r+|S||_dSWn)tk rd}z |SWYdd}~XnXdS)z Make a subp call based on set args and handle errors by setting failure code :return: whether the subp call failed or not captureTN)rrGrF Exception)rIvalueerrZsystemctl_failrrrrs zSystemctlReader.subpcCsE|jr!tdj|j|jjdd}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 ({})=ri@B)r RuntimeErrorrrFr3r5)rIr rrrparse_epoch_as_floats  z$SystemctlReader.parse_epoch_as_float)__name__ __module__ __qualname____doc__rKrrRrrrrrEs  rEcCsCtrtStjs8dtjdjkr?tStS)a2 Determine which init system a particular linux distro is using. Each init system (systemd, upstart, 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 r\c Csytjdgdd\}}|dj}x|D]}|jdjdd kr8|jdj}|djd}t|}ttjttj }||}t |||fSq8WWnt 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 ZdmesgrLTrzUTF-8userr]) r splitlinesr+findr3stripr5timeruptime SUCCESS_CODErMr[) data_Z split_entriesrZsplitupZstrippedZuser_space_timestamp kernel_start kernel_endrrrrZs  "   rZc Cs[ttjttj}ytdj}tddj}|}t}tjrtj dkrttjttj }yt j d}|j }Wn=tk r}ztdj||WYdd}~XnXt}nt}||}||}Wn3tk rJ} zt| tSWYdd} ~ XnX||||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)rjrj)r5rcrrdrErRreZ is_containersys version_infoZ monotonicr(statst_atimeOSErrorrQrCONTAINER_CODE FAIL_CODErMprintr[) rhZ delta_k_endZ delta_ci_sZ base_timeZstatusZ file_statrOriZcloudinit_sysderrrrXs0" "  "   rXFz(%n) %d seconds in %I%DcCsIt|ddd}g}d}d}i} g} g} g} xtdt|D]} || }y|| d}Wntk rd}YnXt|dkr|jd | kr|jt|| j|g}d}d}|dkrg} t|}|| t |/sz"generate_records..Ngrrr:r r;zStarting stage: %szFinished stage: (%n) %d seconds r)sortedrangelen IndexErrorrr0r,rDr8r4r1r!rCpop)eventsZ blame_sort print_formatZ dump_filesZ log_datafilesZ sorted_eventsZrecordsrArZstage_start_timeZ stages_seenZ boot_recordsZ unprocessedrsrZnext_evtZprev_evtrBrrrgenerate_recordssZ           rcCst|d|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)r}r~rrr show_eventsjs rc CsF|j}ytj||fSWntk rAd|fSYnXdS)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)Zinfilerfrrrload_events_infilews   rr_r_r_)&r*r7rr(rcrkZ cloudinitrrZcloudinit.distrosrrjoinrZformatting_helprerqrpr[r!r/r1rr4r6r8r9r<rCrDobjectrEr\rZrXrrrrrrrsZ                3  /J