ó ˝-'Nc@sźddlZddlmZddlZddlZddlmZddlmZdd„Zde fd„ƒYZ d e fd „ƒYZ d e fd „ƒYZ d efd„ƒYZ dS(i˙˙˙˙N(tdatetime(t to_timestamp(t MonitorPluginu /proc/uptimecCs1t|dƒjƒ}|jƒ\}}t|ƒS(s„ This parses a file in /proc/uptime format and returns a floating point version of the first value (the actual uptime). tr(tfiletreadlinetsplittfloat(t uptime_filetdatatuptidle((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyt get_uptime st LoginInfocBseZdZdZd„ZRS(s=Information about a login session gathered from wtmp or utmp.thi32s4s32s256shhiiiiiii20scCsŐtj|j|ƒ}|d|_|d|_|djdƒ|_|djdƒ|_|djdƒ|_|djdƒ|_ |d|_ |d |_ |d |_ t j|d ƒ|_|d |_dS( Niiitiiiiiii i (tstructtunpackt RAW_FORMATt login_typetpidtstript tty_devicetidtusernamethostnamettermination_statust exit_statust session_idRtutcfromtimestampt entry_timetremote_ip_address(tselftraw_datatinfo((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyt__init__s     (t__name__t __module__t__doc__RR#(((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyR stLoginInfoReadercBs)eZdZd„Zd„Zd„ZRS(s=Reader parses C{/var/log/wtmp} and/or C{/var/run/utmp} files.cCs"||_tjtjƒ|_dS(s(Initialize the reader with an open file.N(t_fileRtcalcsizeR Rt_struct_length(R R((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyR#1s ccs,x%tr'|jƒ}|sPn|VqWdS(s2Returns a generator that yields LoginInfo objects.N(tTruet read_next(R R"((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyt login_info6s   cCs>|jj|jƒ}|r:t|ƒ|jkr:t|ƒSdS(s9Returns login data or None if no login data is available.N(R(treadR*tlenR tNone(R R ((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyR,@s (R$R%R&R#R-R,(((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyR'.s  t BootTimescBs8eZdZdZdddd„Zd„Zd„ZRS(s /var/log/wtmpicCs||_||_||_dS(N(t _filenamet_boots_newer_thant_shutdowns_newer_than(R tfilenametboots_newer_thantshutdowns_newer_than((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyR#Ns  cCsěg}g}tt|jƒƒ}|j|_|j|_xŚ|jƒD]˜}|jj dƒrFt |j ƒ}|j dkr¤||jkr¤|j |ƒ||_qŢ|j dkrŢ||jkrŢ|j |ƒ||_qŢqFqFW||fS(Nt~treboottshutdown(R'RR2R3t _last_bootR4t_last_shutdownR-Rt startswithRRRtappend(R t reboot_timestshutdown_timestreaderR"t timestamp((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyt get_timesTs"     cCs5|jdkr.ttjƒtƒƒ|_n|jS(N(R;R0tintttimeR (R ((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pytget_last_boot_timehsN(R$R%R0R;R<R#RCRF(((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyR1Js  tComputerUptimecBsJeZdZdZdd„Zd„Zed„Zed„Zd„Z RS(s1Plugin reports information about computer uptime.scomputer-uptimes /var/log/wtmpcCst|_||_dS(sInitialize the plugin.N(R+t _first_runt _wtmp_file(R t wtmp_file((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyR#ss cCsFtt|ƒj|ƒ|jjd|jƒ|jd|jtƒdS(s7Register this plugin with the specified plugin manager.trunscomputer-uptimeN(tsuperRGtregistertreactortcall_onRKtcall_on_acceptedR+(R tregistry((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyRMxscCs‹|jj}|jrS|jd}tjj|ƒrS|jd|j||ƒqSntjj|jƒr‡|jd|j|j|ƒndS(sJCreate a message and put it on the message queue. The last logrotated file, if it exists, will be checked the first time the plugin runs. This behaviour ensures we don't accidentally miss a reboot/shutdown event if the machine is rebooted and wtmp is logrotated before the client starts. s.1scomputer-uptimeN( RQtbrokerRHRItostpathtisfiletcall_if_acceptedt send_message(R turgentRRR5((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyRK~s    cCsQ|j|ƒ}d|ks'd|krMd|d<|jjj|d|ƒndS(Nsshutdown-timess startup-timesscomputer-uptimettypeRX(t_create_messageRQRRRW(R R5RXtmessage((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyRW‘s cCsži}g}g}|jjddƒ}|jjddƒ}t|d|d|ƒ}|jƒ\}}|r|jjd|dƒ||ds    $