| Server IP : 184.154.167.98 / Your IP : 18.118.184.76 Web Server : Apache System : Linux pink.dnsnetservice.com 4.18.0-553.22.1.lve.1.el8.x86_64 #1 SMP Tue Oct 8 15:52:54 UTC 2024 x86_64 User : puertode ( 1767) PHP Version : 8.2.27 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /usr/lib64/python3.6/site-packages/pcp/__pycache__/ |
Upload File : |
3
4>�fqc � @ s� d Z ddlZddlmZmZmZmZmZ ddlm Z m
Z
m Z m Z m
Z
ddlmZmZmZmZmZmZmZmZ G dd� de�ZG dd � d e�ZG d
d � d e �ZG d d
� d
e�Z G dd� de�Z G dd� dee�Z dS )zA Convenience Classes building on the base PMAPI extension module � N)�c_int�c_uint�c_char_p�cast�POINTER)� pmContext�pmValue�pmDesc�pmErr�timeval)�PM_CONTEXT_HOST�PM_CONTEXT_ARCHIVE�
PM_INDOM_NULL�
PM_IN_NULL�
PM_ID_NULL�PM_SEM_COUNTER�
PM_ERR_EOL�PM_TYPE_DOUBLEc @ s e Zd ZdZdd� ZdS )�
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).
c C s< || _ t|t�s|jd�}|| _|| _d | _d | _d | _d S )Nzutf-8) �ctx�
isinstance�bytes�encode�name�pmid�desc�text�help)�selfr r r � r � /usr/lib64/python3.6/pmcc.py�__init__+ s
zMetricCore.__init__N)�__name__�
__module__� __qualname__�__doc__r! r r r r r s r c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zeed0d0d0�Z eed0d0d0�Z eed0d0d0�Z eed0d0d0�Z ee d0d0d0�Z ee
d0d0d0�Z!eeed0d0�Z"eed0d0d0�Z#eeed0d0�Z$eeed0d0�Z%eed0d0d0�Z&eed0d0d0�Z'eed0d0d0�Z(eed0d0d0�Z)d1d2� Z*d3d4� Z+d0S )5�Metricz�
Additional metric information, such as conversion factors and values
several instances of Metric may share a MetricCore instance
c C sL || _ d | _d | _d | _d | _|jjj| _d | _ d | _
d | _ d | _ d | _
d S )N)�_core�_vset�_values� _prevvset� _prevValuesr �contents�type� _convType�
_convUnits� _errorStatus�
_netValues�_netPrevValuesZ_netConvertedValues)r �corer r r r! ? s zMetric.__init__c C s | j jS )N)r' r )r r r r �_R_ctxO s z
Metric._R_ctxc C s | j jj� S )N)r' r �decode)r r r r �_R_nameQ s zMetric._R_namec C s | j jS )N)r' r )r r r r �_R_pmidS s zMetric._R_pmidc C s | j jS )N)r' r )r r r r �_R_descU s zMetric._R_descc C s | j jS )N)r' r )r r r r �_R_textW s zMetric._R_textc C s | j jS )N)r' r )r r r r �_R_helpY s zMetric._R_helpc C s t |jjtt��}|| S )z% Return the vlist[vlist_idx] of vset )r r, Zvlistr r )r �vset� vlist_idxZlistptrr r r � get_vlist\ s zMetric.get_vlistc C s | j ||�jS )z. Return the inst for vlist[vlist_idx] of vset )r= �inst)r r; r< r r r �get_insta s zMetric.get_instc C s� |}| j }|j| jjj�}g }x�t|j�D ]�}| j||�}y||j }W n t k
r` d}Y nX | j j
|j || jj | j
�} | jr�tt�d � }
| j|
d< | j j| j
| |
d| j�} | j| j
�} |j||| f� q*W |S )zj Extract the value for a singleton or list of instances
as a triple (inst, name, val)
� � r )r �
mcGetInstDr r, �indom�range�numvalr= r> �KeyError�pmExtractValue�valfmtr- r. r/ r r � pmConvScale�dref�append) r ZinValuesr; r �instD�valL�i�instvalr �outAtomr �valuer r r �
computeValuese s(
zMetric.computeValuesc C sV ||j kr$| j||�}||jkr$|S x,t|j �D ] }| j||�}||jkr0|S q0W dS )z2 Find a metric instance in the previous resultset N)rE r= r> rD )r �indexr> �pvset�pinstvalZpir r r �_find_previous_instval~ s
z Metric._find_previous_instvalc C s^ | j jtkr| j|�S |dkr"dS |}|}| j}|j| j jj�}g }�xt|j �D �]} | j
|| �}
| j | |
j |�} | dkr~qRy||
j } W n t
k
r� d} Y nX | jj|j|
| j jt�}
| jj|j| | j jt�}| j�r"tt�d � }| j |d< | jjt|
|d| j�}
| jjt||d| j�}|
jt�}|jt�}||krR|j|
| || | f� qRW |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).
Nr@ rA r )r �semr rR r rB r, rC rD rE r= rV r> rF rG rH r- r r/ r r rI rJ rK )r �values�
prevValues�deltarT r; r rL rM rN rO rU r rP ZpoutAtomr rQ Zpvaluer r r �
convertValues� sD
zMetric.convertValuesc C s | j S )N)r) )r r r r � _R_values� s zMetric._R_valuesc C s | j S )N)r+ )r r r r �
_R_prevValues� s zMetric._R_prevValuesc C s | j S )N)r. )r r r r � _R_convType� s zMetric._R_convTypec C s | j S )N)r/ )r r r r � _R_convUnits� s zMetric._R_convUnitsc C s | j S )N)r0 )r r r r �_R_errorStatus� s zMetric._R_errorStatusc C s | j S )N)�_netConvValues)r r r r �_R_netConvValues� s zMetric._R_netConvValuesc C s | j s
d S | j| j �| _| jS )N)r* rR r2 )r r r r �_R_netPrevValues� s zMetric._R_netPrevValuesc C s | j s
d S | j| j �| _| jS )N)r( rR r1 )r r r r � _R_netValues� s zMetric._R_netValuesc C s | j | _|| _ | j| _d | _d S )N)r) �_prevZ _netValueZ_netPrev)r rX r r r � _W_values� s zMetric._W_valuesc C s
|| _ d S )N)r. )r rQ r r r � _W_convType� s zMetric._W_convTypec C s
|| _ d S )N)r/ )r rQ r r r � _W_convUnits� s zMetric._W_convUnitsNc C sR | j j| jj�}tdd|� | j j| jj�}x | jD ]\}}}td||� q4W d S )Nz zindom:)r Z
pmInDomStrr rC �printrB � netValues)r Zindomstr�_r �valr r r � metricPrint� s
zMetric.metricPrintc C s | j | j| j|�}|| _| jS )N)r[ r( r* ra )r rZ Z
convertedListr r r �
metricConvert� s zMetric.metricConvert),r" r# r$ r% r! r4 r6 r7 r8 r9 r: r= r? rR rV r[ r\ r] r^ r_ r` rb rc rd rf rg rh �propertyr r r r r r rX rY ZconvTypeZ convUnitsZ errorStatusrj Z
netPrevValuesZ
netConvValuesrm rn r r r r r& 6 sP (r& c @ sF e Zd ZdZedfdd�Zdd� Zdd� Zd d
� Zd d � Z d
d� Z
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
zlocal:c C s0 t j| ||� i | _i | _i | _d| _d| _d S )Nr )r r! � _mcIndomD�
_mcByNameD�
_mcByPmidD�
_mcCounter�
_mcMetrics)r �typed�targetr r r r! s zMetricCache.__init__c C s
| j | S )z/ Query the instance : instance_list dictionary )rq )r rC r r r rB s zMetricCache.mcGetInstDc C s� |j jj}|| jkr�t|�jtt�jkr2tdi}nP| jt krN| j
|j �\}}n| j |j �\}}|dk r~|dk r~t t
||��}ni }| jj||i� |j jjtkr�| jd7 _| jd7 _| jj|jj� |i� | jj|j|i� dS )z Update the dictionary s
PM_IN_NULLNrA )r r, rC rq r rQ r r Z_typer
ZpmGetInDomArchiveZ
pmGetInDom�dict�zip�updaterW r rt ru rr r r5 rs r )r r3 rC ZinstmapZinstL�nameLr r r �_mcAdd s
zMetricCache._mcAddc C s� g }d}d}xVt |�D ]J\}}t|t�r0|j� }| jj|�}|sV|sHi }|j||i� |j|� qW |r�| j|j � �\}}xD|D ]<\}} | t
kr�|s�g }|j|� q�| j || �}
|
||| < q�W ||fS )z3 Update the core (metric id, description,...) list N) � enumerater r r5 rr �getrz rK � mcFetchPmids�keysr �
_mcCreateCore) r r{ �coreLZmissD�errLrS r r3 ZidLr �newcorer r r �mcGetCoresByName+ s,
z MetricCache.mcGetCoresByNamec C sv t | ||�}y| j|�|_W nJ tk
rf } z.d|j� |j� f }tjj|� t d��W Y dd}~X nX | j
|� |S )z Update the core description z%s: pmLookupDesc: %srA N) r Z pmLookupDescr r
�progname�message�sys�stderr�write�
SystemExitr| )r r r r� �error�failr r r r� N s
zMetricCache._mcCreateCorec
C s� d}t t|� � }x4t|�D ](\}}t|t�s8|jd�}t |�||< q W yJ| j|�}t|�t|�k r�dt|�t|�f }tjj d| � t
d��W nJ t k
r� } z.d|j � |j
� f } tjj | � t
d��W Y dd}~X nX t||�|fS )zD Update the core metric ids. note: some names have identical pmids Nzutf-8z%d of %d metric nameszCannot resolve %srA z%s: pmLookupName: %s)r �lenr} r r r � pmLookupNamer� r� r� r� r
r� r� ry )
r r{ r� �nameArS r � pmidArray�missingr� r� r r r r \ s"
zMetricCache.mcFetchPmidsN) r" r# r$ r% r r! rB r| r� r� r r r r r rp � s #rp c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z e eddd�Z
e eddd�Ze eddd�Ze ee dd�Ze eddd�Ze e
ddd�Ze e ddd�Zg fdd�Zdd� Zdd� Zdd� Zdd � ZdS ) � 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
c C s | j S )N)�_ctx)r r r r �_R_contextCache s zMetricGroup._R_contextCachec C s | j j| j jkS )N)r� rt ru )r r r r �_R_nonCounters� s zMetricGroup._R_nonCountersc C s | j S )N)�
_pmidArray)r r r r � _R_pmidArray� s zMetricGroup._R_pmidArrayc C s
| j jjS )N)�_resultr, � timestamp)r r r r � _R_timestamp� s zMetricGroup._R_timestampc C s | j S )N)r� )r r r r � _R_result� s zMetricGroup._R_resultc C s
| j jjS )N)re r, r� )r r r r �_R_prevTimestamp� s z MetricGroup._R_prevTimestampc C s | j S )N)re )r r r r �_R_prev� s zMetricGroup._R_prevc C s | j | _|| _ d S )N)r� re )r Zpmresultr r r � _W_result� s zMetricGroup._W_resultNc C s6 t j| � || _d | _d | _d | _i | _| j|� d S )N)rx r! r� r� r� re �_altD�mgAdd)r � contextCache�inLr r r r! � s
zMetricGroup.__init__c C s* || krt d��tj| |t| |d�� d S )Nz)metric group with that key already exists)r� )rF rx � __setitem__r� )r �attrrQ r r r r� � s zMetricGroup.__setitem__c C s� | j j|�\}}x6|D ].}t|�}| j|j|i� | jj|j|i� qW t| �}t| � | _ x,t
| j � �D ] \}}t| | j�| j |< qjW dS )z Create the list of Metric(s) N) r� r� r& rz r r� r r� r r� r} r� ) r r{ r� rk r3 Zmetric�n�x�keyr r r r� � s
zMetricGroup.mgAddc C s� yp| j j| j�| _| jj}xRt| jjj�D ]@}| jjj|�}| jjj|�}| j | j
| j | _ || j | _
q*W W n` t k
r� } zD|j
d tkr�td��d|j� |j� f }tjj|� td��W Y dd}~X nX |jS )zl
Fetch the list of Metric values. Save the old value.
Return the result timestamp.
r z%s: pmFetch: %srA N)r� ZpmFetchr� �resultr, rD ZnumpmidZget_pmidZget_vsetr� r( r* r
�argsr r� r� r� r� r� r� r� )r r� rN r r; r� r� r r r �mgFetch� s zMetricGroup.mgFetchc C s( | j dk rt| j�}nd}t| j�| S )z�
Sample delta - used for rate conversion calculations, which
requires timestamps from successive samples.
Ng )re �float�
prevTimestampr� )r r� r r r �mgDelta� s
zMetricGroup.mgDelta)r" r# r$ r% r� r� r� r� r� r� r� r� ro r� � nonCountersr� r� r� �prevr� r! r� r� r� r� r r r r r� r s* r� c @ s e Zd ZdZdd� Zdd� ZdS )�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.
c C s< x6|j � D ]*}|| }x |j � D ]}|| j� q W q
W dS )z0 Base implementation, all tools should override N)r� rm )r �manager�
group_name�group� metric_namer r r �report� s zMetricGroupPrinter.reportc C sF x@|j � D ]4}|| }|j� }x |j � D ]}|| j|� q(W q
W dS )z1 Do conversion for all metrics across all groups N)r� r� rn )r r� r� r� rZ r� r r r �convert� s
zMetricGroupPrinter.convertN)r" r# r$ r% r� r� r r r r r� � s r� c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z e eedd�Z
e eedd�Ze ee dd�Ze de
dd�Ze e ddd�Zedfdd�Zdd� Zedd� �Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Z dS )&�MetricGroupManagerz�
Manages a dictionary of MetricGroups which can be pmFetch'ed
inherits from MetricCache, which inherits from pmContext
c C s | j S )N)�_options)r r r r �
_R_options s z MetricGroupManager._R_optionsc C s
|| _ d S )N)r� )r �optionsr r r �
_W_options s z MetricGroupManager._W_optionsc C s | j S )N)�_default_delta)r r r r �_R_default_delta
s z#MetricGroupManager._R_default_deltac C s
|| _ d S )N)r� )r rZ r r r �_W_default_delta s z#MetricGroupManager._W_default_deltac C s | j S )N)�_default_pause)r r r r �_R_default_pause s z#MetricGroupManager._R_default_pausec C s
|| _ d S )N)r� )r �pauser r r �_W_default_pause s z#MetricGroupManager._W_default_pausec C s
|| _ d S )N)�_printer)r �printerr r r �
_W_printer s z MetricGroupManager._W_printerc C s | j S )N)�_counter)r r r r �
_R_counter s z MetricGroupManager._R_counterNzlocal:c C s@ t j| � tj| ||� d | _tdd�| _d | _d | _d| _d S )NrA r ) rx r! rp r� r r� r� r� r� )r rv rw r r r r! % s
zMetricGroupManager.__init__c C s* || krt d��tj| |t| |d�� d S )Nz)metric group with that key already exists)r� )rF rx r� r� )r r� rQ r r r r� . s z MetricGroupManager.__setitem__c C s$ | j ||�}t|jd�|_||_|S )z8 Helper interface, simple PCP monitor argument parsing. r )Z fromOptionsr rZ r� r� )�clsr� �argvr� r r r �builder3 s zMetricGroupManager.builderc C s$ |dkr dS t |j�t |j�d S )z- convert timeval to epoch seconds as a float Ng g ��.A)r� Ztv_secZtv_usec)r Ztvr r r � _tv2float> s z MetricGroupManager._tv2floatc C s� | j dkrdS d}x | j� D ]}| | jr d}q W | j j� }|dk rP|| dfS | j j� dkrbdS | j j� }| j j� }| j j� }|dkr�| j}| j |�}| j |�| 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.
Nr rA g �?)r N)r N) r� r� r� ZpmGetOptionSamplesZpmGetOptionFinishOptargZpmGetOptionOriginZpmGetOptionFinish�pmGetOptionIntervalr� r� �int) r Zextrar� �samples�origin�finishrZ ZperiodZwindowr r r �_computeSamplesD s&
z"MetricGroupManager._computeSamplesc C sd | j dk r| j S | jtkr(tdd�| _ n6| jdk rV| jj� }|dk rL|| _ q^| j| _ n| j| _ | j S )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 )r� r- r
r r� r� r� )r r� r r r �_computePauseTimec s
z$MetricGroupManager._computePauseTimec C s� g }t t|� � }x4t|�D ](\}}t|t�s8|jd�}t |�||< q W ytj| |� W n^ tk
r� xHt|�D ]<\}}ytj| |� W qr tk
r� |j || � Y qrX qrW Y nX |s�dS |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.
zutf-8N)
r r� r} r r r r r� r
rK )r r{ r� r� rN r� r r r �checkMissingMetricsx s"
z&MetricGroupManager.checkMissingMetricsc C sN d}d}x@| j � D ]4}| | j� }|dks8| j|�|kr|}| j|�}qW |S )z/ Perform fetch operation on all of the groups. Ng )r� r� r� )r Z fetchtimeZrmaxr� Zstampr r r �fetch� s zMetricGroupManager.fetchc C s� | j � \}}| j� }yv| j� }xh| j| ko4dkn r<P |dk rZ| j|�| j|�krZP | jj| � |j� | j� }| jd7 _q W W n2 tk
r� } z|S d}~X n t k
r� Y nX dS )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.
r NrA )
r� r� r� r� r� r� r� Zsleepr� �KeyboardInterrupt)r r� r� ZtimerZcurtime�coder r r �run� s$ zMetricGroupManager.run) r" r# r$ r% r� r� r� r� r� r� r� r� ro r� Z
default_deltaZ
default_pauser� Zcounterr r! r� � classmethodr� r� r� r� r� r� r� r r r r r� � s. r� ) r% r� Zctypesr r r r r Z pcp.pmapir r r r
r Zcpmapir r
r r r r r r �objectr r& rp rx r� r� r� r r r r �<module> s ( B{q