ó ÍÿŠTc@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(swReader parses C{/var/log/wtmp} and/or C{/var/run/utmp} files. @file: Initialize the reader with an open file. cCs"||_tjtjƒ|_dS(N(t_fileRtcalcsizeR Rt_struct_length(R R((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyR#4s 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_info8s   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,Bs (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#Ps  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_timesVs"     cCs5|jdkr.ttjƒtƒƒ|_n|jS(N(R;R0tintttimeR (R ((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pytget_last_boot_timejsN(R$R%R0R;R<R#RCRF(((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyR1Ls  tComputerUptimecBsPeZdZdZdZdd„Zd„Zed„Zed„Z d„Z RS( s1Plugin reports information about computer uptime.scomputer-uptimetcomputers /var/log/wtmpcCst|_||_dS(N(R+t _first_runt _wtmp_file(R t wtmp_file((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyR#vs cCsFtt|ƒj|ƒ|jjd|jƒ|jd|jtƒdS(s7Register this plugin with the specified plugin manager.trunscomputer-uptimeN(tsuperRGtregistertreactortcall_onRLtcall_on_acceptedR+(R tregistry((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyRNzscCs‹|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( RRtbrokerRIRJtostpathtisfiletcall_if_acceptedt send_message(R turgentRSR5((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyRL€s     cCsW|j|ƒ}d|ks'd|krSd|d<|jjj||jd|ƒndS(Nsshutdown-timess startup-timesscomputer-uptimettypeRY(t_create_messageRRRSRXt _session_id(R R5RYtmessage((sD/usr/lib/python2.7/dist-packages/landscape/monitor/computeruptime.pyRX•s  cCs¾i}g}g}|jjddƒ}|jjddƒ}t|d|d|ƒ}|jƒ\}}|r|jjd|dƒ||ds    $