iogqcSrSSKrSSKJrJrJrJrJr SSKJ r J r J r J r J r SSKJrJrJrJrJrJrJrJr "SS\5r"SS \5r"S S \ 5r"S S \5r"SS\5r"SS\\5rg)z@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\rSrSrSrSrSrg) MetricCore a 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). cXl[U[5(dURS5nX lX0lSUlSUlSUlg)Nutf-8) ctx isinstancebytesencodenamepmiddesctexthelp)selfrrrs */usr/lib/python3/dist-packages/pcp/pmcc.py__init__MetricCore.__init__+sA$&&;;w'D     )rr r"rrr!N)__name__ __module__ __qualname____firstlineno____doc__r%__static_attributes__r'r$rr s r'rc\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSrSrSrSrSrSrSr\"\SSS5r\"\SSS5r\"\SSS5r\"\ SSS5r \"\ SSS5r!\"\ SSS5r"\"\\SS5r#\"\SSS5r$\"\\SS5r%\"\\SS5r&\"\SSS5r'\"\SSS5r(\"\SSS5r)\"\SSS5r*Sr+Sr,Sr-g)Metric6z Additional metric information, such as conversion factors and values several instances of Metric may share a MetricCore instance cXlSUlSUlSUlSUlUR R RUlSUl SUl SUl SUl SUl gN)_core_vset_values _prevvset _prevValuesr contentstype _convType _convUnits _errorStatus _netValues_netPrevValues_netConvertedValues)r#cores r$r%Metric.__init__?sa   ++00 "#' r'c.URR$r3)r4rr#s r$_R_ctx Metric._R_ctxOszz~~r'cJURRR5$r3)r4rdecoderDs r$_R_nameMetric._R_nameQszz%%''r'c.URR$r3)r4rrDs r$_R_pmidMetric._R_pmidSzzr'c.URR$r3)r4r rDs r$_R_descMetric._R_descUrNr'c.URR$r3)r4r!rDs r$_R_textMetric._R_textWrNr'c.URR$r3)r4r"rDs r$_R_helpMetric._R_helpYrNr'cd[URR[[55nX2$)z$Return the vlist[vlist_idx] of vset )rr9vlistrr )r#vset vlist_idxlistptrs r$ get_vlistMetric.get_vlist\s&t}}**GG,<=!!r'c8URX5R$)z-Return the inst for vlist[vlist_idx] of vset )r]inst)r#rZr[s r$get_instMetric.get_instas~~d.333r'cUnURnURURRR5n/n[ UR 5GHnURX&5nXGRnURRURUURRUR5n UR(aX[[ 5S-"5n URU S'URR#URXSUR5n U R%UR5n UR'XxU 45 GM U$![a SnNf=f)zUExtract the value for a singleton or list of instances as a triple (inst, name, val) r)r mcGetInstDr r9indomrangenumvalr]r`KeyErrorpmExtractValuevalfmtr:r;r<rr pmConvScaledrefappend) r#inValuesrZrinstDvalLiinstvalroutAtomr values r$ computeValuesMetric.computeValueses"hhtyy11778t{{#AnnT-G \\*hh--dkk7.2iinndnnNG!+.))Q((..t~~w/0$//CLL0E KK. /$   s+E E,+E,cXR::a"URX15nX$R:XaU$[UR5H'nURX55nX$R:XdM%Us $ g)z1Find a metric instance in the previous resultset N)rir]r`rh)r#indexr`pvsetpinstvalpis r$_find_previous_instvalMetric._find_previous_instval~s^ LL ~~e3H}}$ %B~~e0H}}$&r'cURR[:waURU5$UcgUnUnURnUR URR R5n/n[UR5GHn URXY5n URXRU5n U cM6XzRn URRURU URR ["5n URRURU URR ["5nUR$(a~['[(5S-"5nURUS'URR+["XSUR$5n URR+["XSUR$5nU R-["5nUR-["5nUU:dGMUR/XUU- U- 45 GM U$![a Sn GNqf=f)zExtract 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). Nrdrer)r semrrwrrfr9rgrhrir]r~r`rjrkrlr:rr<rr rmrnro)r#values prevValuesdeltar{rZrrqrrrsrtr|rrupoutAtomr rvpvalues r$ convertValuesMetric.convertValuess 99==N *%%f- -  hhtyy11778t{{#AnnT-G221llEJH \\*hh--dkk7.2iinnnNGxx..u||X/3yy~~~OH!+.))Q((..~w/0$//C88//014??DLL0E]]>2F WUV^u,DEF/$0 #  sH11 IIcUR$r3)r6rDs r$ _R_valuesMetric._R_values ||r'cUR$r3)r8rDs r$ _R_prevValuesMetric._R_prevValuessr'cUR$r3r;rDs r$ _R_convTypeMetric._R_convTypes ~~r'cUR$r3r<rDs r$ _R_convUnitsMetric._R_convUnits r'cUR$r3)r=rDs r$_R_errorStatusMetric._R_errorStatuss   r'cUR$r3)_netConvValuesrDs r$_R_netConvValuesMetric._R_netConvValues"""r'c~UR(dgURUR5UlUR$r3)r7rwr?rDs r$_R_netPrevValuesMetric._R_netPrevValuess/~~"00@"""r'c~UR(dgURUR5UlUR$r3)r5rwr>rDs r$ _R_netValuesMetric._R_netValuess,zz,,TZZ8r'cbURUlXlURUlSUlgr3)r6_prev _netValue_netPrev)r#rs r$ _W_valuesMetric._W_valuess$\\   r'cXlgr3rr#rvs r$ _W_convTypeMetric._W_convTypesr'cXlgr3rrs r$ _W_convUnitsMetric._W_convUnitssr'NcURRURR5n[ SSU5 URR URR5nUR Hup#n[ SX45 M g)Nz zindom:)r pmInDomStrr rgprintrf netValues)r#indomstr_rvals r$ metricPrintMetric.metricPrintsb88&&tyy7 eXx( HH    0 NNLAS % #+r'ctURURURU5nX lUR$r3)rr5r7r)r#r convertedLists r$ metricConvertMetric.metricConverts0**4::t~~uM +"""r')r;r<r4r=rr@rr?rr>rr8r7r6r5).r(r)r*r+r,r%rErIrLrPrSrVr]rarwr~rrrrrrrrrrrrpropertyrrrr r!r"rrconvType convUnits errorStatusr netPrevValues netConvValuesrrr-r.r'r$r0r06sk ( (" 42 &P !##     64t ,C GT4 .D GT4 .D GT4 .D GT4 .D GT4 .DiD$ 7F-tT:J [$=H|T4@I>4tEL, ))%0I9~E *1S^SZ4PP   !4w!>? m#+5$d**  -2^^-=u}}OD JJ  T "Q-  s"A/C D=)AD88D=)rrrrrN) r(r)r*r+r,r r%rfrrrrr-r.r'r$rrs--X%20!F +r'rc\rSrSrSrSrSrSrSrSr Sr S r S r \ "\S S S 5r\ "\S S S 5r\ "\S S S 5r\ "\ \ S S 5r\ "\S S S 5r\ "\ S S S 5r\ "\ S S S 5r/4S jrS rSrSrSrSrg ) MetricGroupiral 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 cUR$r3)_ctxrDs r$_R_contextCacheMetricGroup._R_contextCaches yyr'c\URRURR:g$r3)rrrrDs r$_R_nonCountersMetricGroup._R_nonCounterss!yy##tyy';';;;r'cUR$r3) _pmidArrayrDs r$ _R_pmidArrayMetricGroup._R_pmidArrayrr'cBURRR$r3)_resultr9 timestamprDs r$ _R_timestampMetricGroup._R_timestamps||$$...r'cUR$r3)rrDs r$ _R_resultMetricGroup._R_resultrr'cBURRR$r3)rr9rrDs r$_R_prevTimestampMetricGroup._R_prevTimestampszz"",,,r'cUR$r3)rrDs r$_R_prevMetricGroup._R_prevs zzr'c2URUlXlgr3)rr)r#pmresults r$ _W_resultMetricGroup._W_results\\  r'Nc[RU5 XlSUlSUlSUl0UlURU5 gr3)rr%rr rr_altDmgAdd)r# contextCacheinLs r$r%MetricGroup.__init__s: d     3r'c ^X;a [S5e[RX[XS95 gNz)metric group with that key already exists)r%rjr __setitem__rr#attrrvs r$r*MetricGroup.__setitem__( <FG G [%ABr'cURRU5up#UHRn[U5nURURU05 UR RUR U05 MT [U5n[U-"5Ul [UR55H)upx[XR 5URU'M+ g)zCreate the list of Metric(s) N) rrr0rrr"rrrr rr) r#rrrrAmetricnxkeys r$r#MetricGroup.mgAdds99--e4DD\F KKf- . JJ  v{{F3 4 I!A:. ,FA!' !7DOOA -r'cURRUR5UlURRn[ URRR 5HnURRRU5nURRRU5nURURURUl X@RUl M UR*$![avnURS[:Xa [S5eUR!5<SUR#5<3n[$R&R)U5 [S5eSnAff=f)zT Fetch the list of Metric values. Save the old value. Return the result timestamp. rz : pmFetch: reN)rpmFetchr resultr9rhnumpmidget_pmidget_vsetr"r5r7r argsrrrrrrrr)r#r7rsrrZrrs r$mgFetchMetricGroup.mgFetchs  ))++DOOL>4ts, :RYY% "3c"999r'cJURcgSnUR5HnXR(dMSnM URR5nUbX1-S4$URR 5cgURR 5nURR 5nURR5nUc URnURU5nURU5URU5- U- n[US-5U-U4$)aReturn 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)rNrerg?) rVrrDpmGetOptionSamplespmGetOptionFinishOptargpmGetOptionOriginpmGetOptionFinishpmGetOptionIntervalrarint) r#extrarKsamplesoriginfinishrperiodwindows r$_computeSamples"MetricGroupManager._computeSamplesDs == YY[E{&&&!--224  ?D( ( == 0 0 2 :002002 113 =''E&..(4>>&+AAVK6C< 5(&00r'cURb UR$UR[:Xa[SS5UlUR$URbMURR 5nUbXlUR$UR UlUR$UR UlUR$)aFigure 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). r)rjr:rr rVrrarns r$_computePauseTime$MetricGroupManager._computePauseTimecs    *&& & 99* *")!Q-D """]] &MM557E &+# """'+&9&9#"""#'"5"5D """r'c/n[[U5-"5n[U5H8upE[U[5(dUR S5n[U5X4'M: [ R"X5 U(dgU$![aR [U5H@upE[ R"X5 M![a URX5 M>f=f Nef=f)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 ro)r#rrrrsr1s r$checkMissingMetrics&MetricGroupManager.checkMissingMetricsxs CJ&)e$DAa''HHW%{EH% -  " "4 / -!%(-**45-NN58,-) -s6"BCB53C5CCCCCcSnSnUR5HBnXR5nUbURU5U:dM/UnURU5nMD U$)z.Perform fetch operation on all of the groups. Nr?)rr<r)r# fetchtimermaxrKstamps r$fetchMetricGroupManager.fetchs] YY[EK'')E DNN5$9D$@! ~~e, ! r'cUR5upUR5nUR5nURUs=:aS:aO OgUb&UR U5UR U5:agUR R U5 UR5 UR5nU=RS- slM![a nUsSnA$SnAf[a gf=f)a1Using 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. rNre) rrrrxrrsrMsleeprKeyboardInterrupt)r#rrtimercurtimecodes r$runMetricGroupManager.runs..0&&( jjlG==G/a/%$..*AT^^TZE[*[ $$T* **, "  K    s0+C 'C :AC C-CC- C-,C-)rxrarjrVrs)r(r)r*r+r,rWr\rbrerkrpruryrr[ default_delta default_pausertcounterr r%r* classmethodrrrrrrrr-r.r'r$rSrSs #$#$  z:tT:G-/?tLM-/?tLMtZt4Gz4t4G -XC : 1>#*4 r'rS)r,rctypesrrrrr pcp.pmapirr r r r cpmapir rrrrrrrobjectrr0rrrrGrSr.r'r$rs}G. 99@@$$$ ,~#V~#Bx+)x+vn5$n5b880|{|r'