ó ½-'Nc@sÔddlZddlZddlZddlmZddlmZdefd„ƒYZddd„ƒYZddd „ƒYZ d dd „ƒYZ d dd „ƒYZ de fdefde fde fgZ dS(iÿÿÿÿN(tPluginConfigError(t MonitorPlugint ProcessorInfocBsqeZdZdZd Zdd dd„Zd„Zd„Zd„Z e d„Z e d „Z d „Z d „ZRS( súPlugin captures information about the processor(s) in this machine. This plugin runs once per client session. When processor information is retrieved it's compared against the last known processor information, which is saved in persistent storage. A message is only put on the message queue if the latest processor information differs from the last known processor information. The information available from /proc/cpuinfo varies per platform. For example, an Apple PowerMac Dual G5 doesn't contain a vendor ID and provides the processor name in the 'cpu' field, as opposed to the 'model name' field used on x86-based hardware. For reasons such as this, the schema of the data reported by this plugin is flexible. Only 'processor-id' and 'model' are guaranteed to be present. In order to deal with the vagaries of parsing /proc/cpu information on the various platforms we support, message generation is deferred to per-platform message factories. sprocessor-infois /proc/cpuinfocCsJ||_||_|dkr1tjƒd}n|j||ƒ|_dS(s:Initialize plugin with starting delay and source filename.iN(t_delayt_source_filenametNonetostunamet_create_cpu_info_readert_cpu_info_reader(tselftdelayt machine_nametsource_filename((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyt__init__#s     cCsUx>tD]6}tj|dƒ}|j|ƒr|d|ƒSqWtd|ƒ‚dS(sAReturn a message factory suitable for the specified machine name.iis2A processor info reader for '%s' is not available.N(tmessage_factoriestretcompiletmatchR(R R R tpairtregexp((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyR/s  cCsLtt|ƒj|ƒ|jjj|j|jƒ|jd|j t ƒdS(s8Register this plugin with the specified plugin registry.sprocessor-infoN( tsuperRtregistertregistrytreactort call_laterRtruntcall_on_acceptedt send_messagetTrue(R R((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyR:scCsidd6|jjƒd6S(s6Retrieve processor information and generate a message.sprocessor-infottypet processors(R tcreate_message(R ((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyR @s cCsØt}|jƒ}x|dD]„}dt|dƒf}|jj|ƒ}|dkrvi}|j||ƒt}q|j||ƒr|j||ƒt}qqW|rÔt j dƒ|j j j |d|ƒndS(NRt processors processor-ids-Queueing message with updated processor info.turgent(tFalseR tstrt_persisttgetRt_updateRt _has_changedtloggingtinfoRtbrokerR(R R"tdirtytmessageR!tkeytcached_processor((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyREs     cCs |jjjd|j|ƒdS(s1Create a message and put it on the message queue.sprocessor-infoN(RR+tcall_if_acceptedR(R R"((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyRYscCs\|d|dkrtS|d|jddƒkr8tS|d|jddƒkrXtStS(s>Returns true if processor details changed since the last read.tmodeltvendortt cache_sizes cache-sizeiÿÿÿÿ(RR&R#(R R!R-((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyR(^scCso|d|d<|d|d<|jddƒ|d<|jddƒ|d<|jjd t|dƒf|ƒd S( s1Update the processor details with current values.s processor-idtidR1s cache-sizeiÿÿÿÿR4R2R3R!N(R&R%tsetR$(R R!R-((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyR'ks N(t__name__t __module__t__doc__t persist_nameRt run_intervalRRRR R#RRR(R'(((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyR s     tPowerPCMessageFactorycBs eZdZd„Zd„ZRS(s@Factory for ppc-based processors provides processor information.cCs ||_dS(s/Initialize reader with filename of data source.N(R(R R ((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyRxscCsÀg}t|jƒ}z™d}xŒ|D]„}|jddƒ}|djƒ}|dkr†it|djƒƒd6}|j|ƒq%|dkr%|djƒ|d.*?)\s*:\s*(?P.*)R.tvaluet Processoris processor-idR1s Cache sizes cache-sizeN( R?RRRRRAtgroupRBRCRD( R RRERRFRGRR.RJ((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyR šs&      (R7R8R9RR (((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyRI“s tSparcMessageFactorycBs eZdZd„Zd„ZRS(sBFactory for sparc-based processors provides processor information.cCs ||_dS(s/Initialize reader with filename of data source.N(R(R R ((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyR¼sc Csög}d }t|jƒ}zÉtjdƒ}x³|D]«}|jddƒ}|djƒ}|dkr{|djƒ}q4|j|ƒr4tjdƒj|ƒj ƒ\}} it ||| !ƒd6|d6} |j | ƒq4q4WWd |j ƒX|S( s;Returns a list containing information about each processor.s CPU(\d{1})+R=iiR>s\d+s processor-idR1N( RR?RRRR@RARtsearchtspanRBRCRD( R RR1RERRGRHR.tstarttendR-((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyR Às"  $  (R7R8R9RR (((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyRM¹s tX86MessageFactorycBs eZdZd„Zd„ZRS(s@Factory for x86-based processors provides processor information.cCs ||_dS(s/Initialize reader with filename of data source.N(R(R R ((sC/usr/lib/python2.7/dist-packages/landscape/monitor/processorinfo.pyRÝscCsg}t|jƒ}zõd }xè|D]à}|jddƒ}|djƒ}|dkr†it|djƒƒd6}|j|ƒq%|dkr©|djƒ|ds   l&!#