grthtrhthjhtyjytjytkergtrhtrjytjerhrfh4:24 29/09/2026a jqc@sdZddlZddlmZmZmZmZmZddlm Z m Z m Z m Z m Z ddlmZmZmZmZmZmZmZmZGdddeZGdd d eZGd d d e ZGd d d eZGdddeZGdddeeZdS)zA Convenience Classes building on the base PMAPI extension module N)c_intc_uintc_char_pcastPOINTER) pmContextpmValuepmDescpmErrtimeval)PM_CONTEXT_HOSTPM_CONTEXT_ARCHIVE PM_INDOM_NULL PM_IN_NULL PM_ID_NULLPM_SEM_COUNTER PM_ERR_EOLPM_TYPE_DOUBLEc@seZdZdZddZdS) MetricCorea Core metric information that can be queried from the PMAPI PMAPI metrics are unique by name, and MetricCores should be also rarely, some PMAPI metrics with different names might have identical PMIDs PMAPI metrics are unique by (name) and by (name,pmid) - _usually_ by (pmid) too. Note that names here (and only here) are stored as byte strings for direct PMAPI access. All dictionaries/caching strategies built using the core structure use native strings (i.e., not byte strings in python3). cCs<||_t|ts|d}||_||_d|_d|_d|_dS)Nutf-8) ctx isinstancebytesencodenamepmiddesctexthelp)selfrrrr ./usr/lib64/python3.9/site-packages/pcp/pmcc.py__init__+s  zMetricCore.__init__N)__name__ __module__ __qualname____doc__r"r r r r!r s rc@seZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ ddZddZddZddZddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Zd*d+Zd,d-Zd.d/Zeed0d0d0Zeed0d0d0Zeed0d0d0Zeed0d0d0Zee d0d0d0Z ee d0d0d0Z!eeed0d0Z"eed0d0d0Z#eeed0d0Z$eeed0d0Z%eed0d0d0Z&eed0d0d0Z'eed0d0d0Z(eed0d0d0Z)d1d2Z*d3d4Z+d0S)5Metricz Additional metric information, such as conversion factors and values several instances of Metric may share a MetricCore instance cCsL||_d|_d|_d|_d|_|jjj|_d|_ d|_ d|_ d|_ d|_ dSN)_core_vset_values _prevvset _prevValuesrcontentstype _convType _convUnits _errorStatus _netValues_netPrevValuesZ_netConvertedValues)rcorer r r!r"?s zMetric.__init__cCs|jjSr()r)rrr r r!_R_ctxOsz Metric._R_ctxcCs |jjSr()r)rdecoder6r r r!_R_nameQszMetric._R_namecCs|jjSr()r)rr6r r r!_R_pmidSszMetric._R_pmidcCs|jjSr()r)rr6r r r!_R_descUszMetric._R_desccCs|jjSr()r)rr6r r r!_R_textWszMetric._R_textcCs|jjSr()r)rr6r r r!_R_helpYszMetric._R_helpcCst|jjtt}||S)z% Return the vlist[vlist_idx] of vset )rr.Zvlistrr)rvset vlist_idxZlistptrr r r! get_vlist\szMetric.get_vlistcCs|||jS)z. Return the inst for vlist[vlist_idx] of vset )r@inst)rr>r?r r r!get_instaszMetric.get_instc Cs|}|j}||jjj}g}t|jD]}|||}z||j}Wnt y\d}Yn0|j |j ||jj |j } |jrttd} |j| d<|j|j | | d|j} | |j } |||| fq(|S)zj Extract the value for a singleton or list of instances as a triple (inst, name, val) r)r mcGetInstDrr.indomrangenumvalr@rAKeyErrorpmExtractValuevalfmtr/r0r1rr pmConvScaledrefappend) rZinValuesr>rinstDvalLiinstvalroutAtomrvaluer r r! computeValueses,       zMetric.computeValuescCsV||jkr$|||}||jkr$|St|jD]"}|||}||jkr.|Sq.dS)z2 Find a metric instance in the previous resultset N)rHr@rArG)rindexrApvsetpinstvalZpir r r!_find_previous_instval~s      zMetric._find_previous_instvalc CsV|jjtkr||S|dur"dS|}|}|j}||jjj}g}t|j D]} | || } | | | j |} | durzqNz|| j } Wnt yd} Yn0|j|j| |jjt} |j|j| |jjt}|jrttd}|j|d<|jt| |d|j} |jt||d|j}| t}|t}||krN|| | |||fqN|S)z Extract the value for a singleton or list of instances as a triple (inst, name, val) for COUNTER metrics with the value delta calculation applied (for rate conversion). NrCrDr)rsemrrUrrEr.rFrGrHr@rYrArIrJrKr/rr1rr rLrMrN)rvalues prevValuesdeltarWr>rrOrPrQrRrXrrSZpoutAtomrrTZpvaluer r r! convertValuessL            zMetric.convertValuescCs|jSr()r+r6r r r! _R_valuesszMetric._R_valuescCs|jSr()r-r6r r r! _R_prevValuesszMetric._R_prevValuescCs|jSr(r0r6r r r! _R_convTypeszMetric._R_convTypecCs|jSr(r1r6r r r! _R_convUnitsszMetric._R_convUnitscCs|jSr()r2r6r r r!_R_errorStatusszMetric._R_errorStatuscCs|jSr()_netConvValuesr6r r r!_R_netConvValuesszMetric._R_netConvValuescCs|js dS||j|_|jSr()r,rUr4r6r r r!_R_netPrevValuesszMetric._R_netPrevValuescCs|js dS||j|_|jSr()r*rUr3r6r r r! _R_netValuesszMetric._R_netValuescCs |j|_||_|j|_d|_dSr()r+_prevZ _netValueZ_netPrev)rr[r r r! _W_valuesszMetric._W_valuescCs ||_dSr(rarrTr r r! _W_convTypeszMetric._W_convTypecCs ||_dSr(rcrlr r r! _W_convUnitsszMetric._W_convUnitsNcCsN|j|jj}tdd||j|jj}|jD]\}}}td||q2dS)Nz zindom:)rZ pmInDomStrrrFprintrE netValues)rZindomstr_rvalr r r! metricPrints  zMetric.metricPrintcCs||j|j|}||_|jSr()r^r*r,rf)rr]Z convertedListr r r! metricConvertszMetric.metricConvert),r#r$r%r&r"r7r9r:r;r<r=r@rBrUrYr^r_r`rbrdrergrhrirkrmrnpropertyrrrrrrr[r\ZconvTypeZ convUnitsZ errorStatusrpZ netPrevValuesZ netConvValuesrsrtr r r r!r'6sP (r'c@sFeZdZdZedfddZddZddZd d Zd d Z d dZ dS) MetricCachea} A cache of MetricCores is kept to reduce calls into the PMAPI library this also slightly reduces the memory footprint of Metric instances that share a common MetricCore a cache of instance domain information is also kept, which further reduces calls into the PMAPI and reduces the memory footprint of Metric objects that share a common instance domain local:cCs0t|||i|_i|_i|_d|_d|_dS)Nr)rr" _mcIndomD _mcByNameD _mcByPmidD _mcCounter _mcMetricsrtypedtargetr r r!r"s zMetricCache.__init__cCs |j|S)z/ Query the instance : instance_list dictionary )rx)rrFr r r!rEszMetricCache.mcGetInstDcCs|jjj}||jvrt|jttjkr2tdi}nP|jt krN| |j\}}n| |j\}}|dur~|dur~t t ||}ni}|j||i|jjjtkr|jd7_|jd7_|j|j|i|j|j|idS)z Update the dictionary s PM_IN_NULLNrD)rr.rFrxrrTrrZ_typer ZpmGetInDomArchiveZ pmGetInDomdictzipupdaterZrr{r|ryrr8rzr)rr5rFZinstmapZinstLnameLr r r!_mcAdds     zMetricCache._mcAddc Csg}d}d}t|D]J\}}t|tr.|}|j|}|sT|sFi}|||i||q|r|| \}}|D]<\}} | t kr|sg}||qz| || } | |||<qz||fS)z3 Update the core (metric id, description,...) list N) enumeraterrr8rygetrrN mcFetchPmidskeysr _mcCreateCore) rrcoreLZmissDerrLrVrr5ZidLrnewcorer r r!mcGetCoresByName+s,      zMetricCache.mcGetCoresByNamec Csxt|||}z|||_WnLtyh}z4d||f}tj|t dWYd}~n d}~00| ||S)z Update the core description z%s: pmLookupDesc: %srDN) rZ pmLookupDescrr prognamemessagesysstderrwrite SystemExitr)rrrrerrorfailr r r!rNs   zMetricCache._mcCreateCorec Csd}tt|}t|D](\}}t|ts6|d}t|||<qzJ||}t|t|krdt|t|f}tj d|t dWnLt y}z4d| | f} tj | t dWYd}~n d}~00t|||fS)zD Update the core metric ids. note: some names have identical pmids Nrz%d of %d metric nameszCannot resolve %srDz%s: pmLookupName: %s)rlenrrrr pmLookupNamerrrrr rrr) rrrnameArVr pmidArraymissingrrr r r!r\s"     zMetricCache.mcFetchPmidsN) r#r$r%r&r r"rErrrrr r r r!rvs  #rvc@seZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ e edddZ e edddZe edddZe ee ddZe edddZe e dddZe e dddZgfddZddZddZddZddZdS) MetricGroupa Manages a group of metrics for fetching the values of a MetricGroup is a dictionary of Metric objects, for which data can be fetched from a target system using a single call to pmFetch the Metric objects are indexed by the metric name pmFetch fetches data for a list of pmIDs, so there is also a shadow dictionary keyed by pmID, along with a shadow list of pmIDs cCs|jSr()_ctxr6r r r!_R_contextCacheszMetricGroup._R_contextCachecCs|jj|jjkSr()rr{r|r6r r r!_R_nonCountersszMetricGroup._R_nonCounterscCs|jSr() _pmidArrayr6r r r! _R_pmidArrayszMetricGroup._R_pmidArraycCs |jjjSr()_resultr. timestampr6r r r! _R_timestampszMetricGroup._R_timestampcCs|jSr()rr6r r r! _R_resultszMetricGroup._R_resultcCs |jjjSr()rjr.rr6r r r!_R_prevTimestampszMetricGroup._R_prevTimestampcCs|jSr()rjr6r r r!_R_prevszMetricGroup._R_prevcCs|j|_||_dSr()rrj)rZpmresultr r r! _W_resultszMetricGroup._W_resultNcCs6t|||_d|_d|_d|_i|_||dSr()rr"rrrrj_altDmgAdd)r contextCacheinLr r r!r"s zMetricGroup.__init__cCs*||vrtdt||t||ddSNz)metric group with that key already exists)rrIr __setitem__rrattrrTr r r!rszMetricGroup.__setitem__c Cs|j|\}}|D].}t|}||j|i|j|j|iqt|}t||_ t | D]\}}t||j|j |<qddS)z Create the list of Metric(s) N) rrr'rrrrrrrrr) rrrrqr5Zmetricnxkeyr r r!rs zMetricGroup.mgAddc Cszl|j|j|_|jj}t|jjjD]@}|jj|}|jj|}|j |j |j |_ ||j |_ q(Wnbt y}zJ|j dtkrtdd||f}tj|tdWYd}~n d}~00|jS)zl Fetch the list of Metric values. Save the old value. Return the result timestamp. rz%s: pmFetch: %srDN)rZpmFetchrresultr.rGZnumpmidZget_pmidZget_vsetrr*r,r argsrrrrrrrr)rrrQrr>rrr r r!mgFetchs zMetricGroup.mgFetchcCs(|jdurt|j}nd}t|j|S)z Sample delta - used for rate conversion calculations, which requires timestamps from successive samples. N)rjfloat prevTimestampr)rrr r r!mgDeltas  zMetricGroup.mgDelta)r#r$r%r&rrrrrrrrrur nonCountersrrrprevrr"rrrrr r r r!rrs*   rc@s eZdZdZddZddZdS)MetricGroupPrintera Handles reporting of MetricGroups within a GroupManager. This object is called upon at the end of each fetch when new values are available. It is also responsible for producing any initial (or on-going) header information that the tool may wish to report. cCs4|D]&}||}|D]}||qqdS)z0 Base implementation, all tools should override N)rrs)rmanager group_namegroup metric_namer r r!reports  zMetricGroupPrinter.reportcCs>|D]0}||}|}|D]}|||q$qdS)z1 Do conversion for all metrics across all groups N)rrrt)rrrrr]rr r r!converts   zMetricGroupPrinter.convertN)r#r$r%r&rrr r r r!rsrc@seZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ e eeddZ e eeddZe ee ddZe de ddZe e dddZedfddZddZeddZddZddZddZd d!Zd"d#Zd$d%ZdS)&MetricGroupManagerz Manages a dictionary of MetricGroups which can be pmFetch'ed inherits from MetricCache, which inherits from pmContext cCs|jSr(_optionsr6r r r! _R_optionsszMetricGroupManager._R_optionscCs ||_dSr(r)roptionsr r r! _W_optionsszMetricGroupManager._W_optionscCs|jSr(_default_deltar6r r r!_R_default_delta sz#MetricGroupManager._R_default_deltacCs ||_dSr(r)rr]r r r!_W_default_delta sz#MetricGroupManager._W_default_deltacCs|jSr(_default_pauser6r r r!_R_default_pausesz#MetricGroupManager._R_default_pausecCs ||_dSr(rrpauser r r!_W_default_pausesz#MetricGroupManager._W_default_pausecCs ||_dSr()_printer)rprinterr r r! _W_printerszMetricGroupManager._W_printercCs|jSr()_counterr6r r r! _R_counterszMetricGroupManager._R_counterNrwcCs@t|t|||d|_tdd|_d|_d|_d|_dS)NrDr) rr"rvrr rrrrr}r r r!r"%s  zMetricGroupManager.__init__cCs*||vrtdt||t||ddSrrrr r r!r.szMetricGroupManager.__setitem__cCs$|||}t|jd|_||_|S)z8 Helper interface, simple PCP monitor argument parsing. r)Z fromOptionsr r]rr)clsrargvrr r r!builder3s zMetricGroupManager.buildercCs$|dur dSt|jt|jdS)z- convert timeval to epoch seconds as a float Nrg.A)rZtv_secZtv_usec)rZtvr r r! _tv2float>szMetricGroupManager._tv2floatc Cs|jdurdSd}|D]}||jrd}q|j}|durL||dfS|jdur^dS|j}|j}|j}|dur|j}| |}| || ||}t |d||fS)a Return the number of samples we are to take and the finish time, or 0,0 if --finish is not specified. This is based on command line options --samples but also must consider --start, --finish and --interval. If none of these were presented, a zero return means "infinite". Also consider whether the utility needs rate-conversion, automatically increasing the sample count to accommodate when counters metrics are present. N)rNrDrg?) rrrZpmGetOptionSamplesZpmGetOptionFinishOptargZpmGetOptionOriginZpmGetOptionFinishpmGetOptionIntervalrrint) rZextrarsamplesoriginfinishr]ZperiodZwindowr r r!_computeSamplesDs&         z"MetricGroupManager._computeSamplescCsd|jdur|jS|jtkr(tdd|_n6|jdurV|j}|durL||_q^|j|_n|j|_|jS)aV Figure out how long to sleep between samples. This needs to take into account whether we were explicitly asked for a delay (independent of context type, --pause), whether this is an archive or live context, and the sampling --interval (including the default value, if none requested). Nr)rr/r r rrrrr r r!_computePauseTimecs     z$MetricGroupManager._computePauseTimec Csg}tt|}t|D](\}}t|ts6|d}t|||<qzt||WnVtyt|D]:\}}zt||Wqjty| ||Yqj0qjYn0|sdS|S)z Return a list of metrics that are missing from the default context. This is usually only applicable when replaying archives. Return None if all found, else a list of missing metric names. rN) rrrrrrrrr rN)rrrrrQrr r r!checkMissingMetricsxs"    z&MetricGroupManager.checkMissingMetricscCsJd}d}|D]4}||}|dus6|||kr|}||}q|S)z/ Perform fetch operation on all of the groups. Nr)rrr)rZ fetchtimeZrmaxrZstampr r r!fetchs   zMetricGroupManager.fetchc Cs|\}}|}zr|}|j|kr4dkr:qnq|durX||||krXq|j|||}|jd7_qWn8ty}z|WYd}~Sd}~0t yYn0dS)av Using options specification, loop fetching and reporting, pausing for the requested time interval between updates. Transparently handles archive/live mode differences. Note that this can be different to the sampling interval in archive mode, but is usually the same as the sampling interval in live mode. rNrD) rrrrrrrsleeprKeyboardInterrupt)rrrZtimerZcurtimecoder r r!runs"   zMetricGroupManager.run)r#r$r%r&rrrrrrrrrurZ default_deltaZ default_pauserZcounterr r"r classmethodrrrrrrrr r r r!rs0   r)r&rZctypesrrrrrZ pcp.pmapirrr r r Zcpmapir r rrrrrrobjectrr'rvrrrrr r r r!s(B{q