| Server IP : 184.154.167.98 / Your IP : 18.191.68.112 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>�fP � @ s8 d Z ddlZddlZddlZddlmZ ddlmZmZm Z m
Z
m Z ddl m
Z
ddlmZmZmZmZmZ ddlmZmZmZmZ ee
d��Zeej_eeeegej_eej _eeeeegej _eej _eeee�ee�gej _eej _eeee�ee�gej _eej _eeeeee�ee�ee�gej _eej _eegej _eej!_eegej!_eej"_eee ��egej"_eej#_ee �egej#_eej$_eee ��egej$_eej%_g ej%_d d
� Z"d d � Z#d
d� Z$dd� Z%G dd� de�Z&G dd� de�Z'G dd� de�Z(G dd� de �Z)G dd� de*�Z+G dd � d e+�Z,dS ) a Wrapper module for libpcp_pmda - Performace Co-Pilot Domain Agent API
#
# Copyright (C) 2013-2015,2017-2021 Red Hat.
#
# This file is part of the "pcp" module, the python interfaces for the
# Performance Co-Pilot toolkit.
#
# This program is free software; you can redistribute it and/or modify it
# under the terms of the GNU General Public License as published by the
# Free Software Foundation; either version 2 of the License, or (at your
# option) any later version.
#
# This program is distributed in the hope that it will be useful, but
# WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
# or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
# for more details.
#
# See pmdasimple.py for an example use of this module.
� N)� pmContext)�pmInDom�pmDesc�pmUnits�pmErr�
pmLabelSet)� find_library)�CDLL�c_int�c_long�c_char_p�c_void_p)� addressof�byref�POINTER� StructureZpcp_pmdac C s. t t�� }tjt|�| �}|dk r*t|��|S )Nr )r r � LIBPCP_PMDA�
pmdaAddLabelsr r )�label�result_p�status� r � /usr/lib64/python3.6/pmda.pyr F s
r c C s t j| |�}|dk r t|��|S )Nr )r �pmdaAddLabelFlagsr )Zlabels�flagsr r r r r M s r c C s. t t�� }tjt|�| �}|dk r*t|��|S )Nr )r r r � pmdaAddNotesr r )r r r r r r r S s
r c C s t j� } | dk rt| ��| S )Nr )r �pmdaGetContextr )r r r r r Z s r c @ s0 e Zd ZdZdefdefgZdd� Zdd� ZdS ) �
pmdaMetricz5 Structure describing a metric definition for a PMDA �m_user�m_descc C s< t j| � d | _|| j_|| j_|| j_|| j_|| j_d S )N) r �__init__r r �pmid�type�indom�sem�units)�selfr! Ztypeofr# r$ r% r r r r i s
zpmdaMetric.__init__c C s dt | �| jj| jjf S )Nz!pmdaMetric@%#lx pmid=%#lx type=%d)r r r! r" )r& r r r �__str__r s zpmdaMetric.__str__N) �__name__�
__module__� __qualname__�__doc__r
r �_fields_r r' r r r r r d s
r c @ s0 e Zd ZdZdefdefgZdd� Zdd� ZdS ) �
pmdaInstidz6 Structure describing an instance (index/name) a PMDA �i_inst�i_namec C s t j| � || _|jd�| _d S )Nzutf-8)r r r. �encoder/ )r& Zinstid�namer r r r z s
zpmdaInstid.__init__c C s dt | �| j| jf S )Nz pmdaInstid@%#lx index=%d name=%s)r r. r/ )r& r r r r' s zpmdaInstid.__str__N) r( r) r* r+ r
r r, r r' r r r r r- u s
r- c @ s� e Zd ZdZdefdefdee�fgZdd� Z dd� Z
d d
� Z d d � Z d
d� Z
dd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd S ) � pmdaIndomz7 Structure describing an instance domain within a PMDA �it_indom�
it_numinst�it_setc C s8 t j| � d| _d | _|| _| j||� | j||� d S )Nr )r r r4 r5 r3 �
load_indom�
set_instances)r& r# �instsr r r r � s
zpmdaIndom.__init__c c s� | j dkrTtj| jtj� xptj| jtj�}|dk r6P | j|�}|r ||fV q W n8x6t| j �D ](}| j | j
}| j|�}|r`||fV q`W d S )Nr ) r4 r � pmdaCacheOpr3 �cpmdaZPMDA_CACHE_WALK_REWINDZPMDA_CACHE_WALK_NEXT�inst_name_lookup�ranger5 r. )r& �instr1 �ir r r �__iter__� s
zpmdaIndom.__iter__c C sv | j dkr@t� }tj| j|t|�d �}|tjkrrt|j j
� �S n2| j dkrrx&| j D ] }|j |krRt|j
j
� �S qRW d S )Nr )r4 r r �pmdaCacheLookupr3 r r: �PMDA_CACHE_ACTIVE�str�value�decoder5 r. r/ )r& �instancer1 �stsr= r r r r; � s
zpmdaIndom.inst_name_lookupc C s t |t�rtj|tj� d S )N)�
isinstance�dictr r9 r: �PMDA_CACHE_LOAD)r& r# r8 r r r r6 � s
zpmdaIndom.load_indomc C s | j dkrtj| jtj� d S )N� ���)r4 r r9 r3 r: rI )r& r r r �load� s
zpmdaIndom.loadc C s\ t |�}t| � }x0t|�D ]$}|| j|| _|| j|| _q W || _|| _tj� d S )N) �lenr- r< r. r/ r5 r4 r: �set_need_refresh)r& r8 Zinstance_countZinstance_arrayr> r r r �set_list_instances� s
z pmdaIndom.set_list_instancesc C s\ t j|tj� x4|j� D ](}|jd�}t j|tj|t|| �� qW t j|tj � d| _
d S )Nzutf-8rJ rK ) r r9 r: �PMDA_CACHE_INACTIVE�keysr0 �pmdaCacheStoreZPMDA_CACHE_ADDr ZPMDA_CACHE_SAVEr4 )r& r# r8 �keyZkey8r r r �set_dict_instances� s
z pmdaIndom.set_dict_instancesc C sF |d krd| _ n2t|t�r.d| _ | j||� nt|�| _ | j|� d S )Nr rJ rK )r4 rG rH rT rM rO )r& r# r8 r r r r7 � s
zpmdaIndom.set_instancesc C s dt | �| j| jf S )Nz pmdaIndom@%#lx indom=%#lx num=%d)r r3 r4 )r& r r r r' � s zpmdaIndom.__str__c C s: | j dkr,tj| jtj�}|dk r6t|��n
ttj��d S )Nr ) r4 r r9 r3 r: rI r �cpmapi�
PM_ERR_NYI)r& rF r r r �
cache_load� s
zpmdaIndom.cache_loadc C s* | j dkr tj| jtj� n
ttj��d S )Nr ) r4 r r9 r3 r: rA r rU rV )r& r r r �cache_mark_active� s
zpmdaIndom.cache_mark_activec C s* | j dkr tj| jtj� n
ttj��d S )Nr ) r4 r r9 r3 r: rP r rU rV )r& r r r �cache_mark_inactive� s
z pmdaIndom.cache_mark_inactivec C s8 | j dkr*tj| j|�}|dk r4t|��n
ttj��d S )Nr )r4 r �pmdaCacheResizer3 r rU rV )r& ZmaximumrF r r r � cache_resize� s
zpmdaIndom.cache_resizeN)r( r) r* r+ r r
r r- r, r r? r; r6 rL rO rT r7 r' rW rX rY r[ r r r r r2 � s"
r2 c @ s e Zd ZdZdd� ZdS )� pmdaUnitszF Wrapper class for PMDAs defining their metrics (avoids pmapi import) c C s t j| ||||||� d S )N)r r )r& ZdimSZdimTZdimCZscaleSZscaleTZscaleCr r r r � s zpmdaUnits.__init__N)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 d dd�Z
dd� Z d dd�Z dd� Z
dd� Zdd� Zdd � Zd S ) �MetricDispatcha� Helper for PMDA class which manages metric dispatch
table, metric namespace, descriptors and help text.
Overall strategy is to interface to the C code in
python/pmda.c here, using a void* handle to the PMDA
dispatch structure (allocated and managed in C code).
In addition, several dictionaries for metric related
strings are managed here (names, help text) - cached
for quick lookups in callback routines.
c C sP g | _ i | _i | _i | _g | _i | _i | _i | _i | _i | _ t
j ||||� d S )N) � _indomtable�_indoms�_indom_oneline�_indom_helptext� _metrictable�_metrics�
_metric_names�_metric_names_map�_metric_oneline�_metric_helptextr: Z
init_dispatch)r& �domainr1 �logfile�helpfiler r r r s zMetricDispatch.__init__c C s. | j d d �= | jj� | jj� | jj� d S )N)r^ r_ �clearr` ra )r& r r r � clear_indoms s
zMetricDispatch.clear_indomsc C sB | j d d �= | jj� | jj� | jj� | jj� | jj� d S )N)rb rc rk rd re rf rg )r& r r r �
clear_metrics0 s
z MetricDispatch.clear_metricsc C s | j � tj� d S )N)rm r: rN )r& r r r �
reset_metrics: s z MetricDispatch.reset_metricsc C s t j| j� d S )N)r: � pmns_refreshrd )r& r r r ro A s zMetricDispatch.pmns_refreshc C s t j� d S )N)r: � connect_pmcd)r& r r r rp D s zMetricDispatch.connect_pmcd� c C sz |j j}|| jkr td| ��|| jkr0td��| jj|� || j|< || j|< || j|< || j|< || j |< t
j � d S )Nz.attempt to add_metric with an existing name=%sz+attempt to add_metric with an existing PMID) r r! re �KeyErrorrc rb �appendrd rf rg r: rN )r& r1 �metric�oneline�textr! r r r �
add_metricG s
zMetricDispatch.add_metricc C s� |j j}|| jkr td| ��|| jkr0td��| jj|� | jj|� | jj|� | jj|� | j j|� | j
j|� t j � d S )Nz-attempt to remove non-existant metric name=%sz/attempt to remove_metric with non-existant PMID)
r r! re rr rc rb �remove�poprd rf rg r: rN )r& r1 rt r! r r r �
remove_metricV s
z MetricDispatch.remove_metricc C sV |j }x | jD ]}|j |krtd��qW | jj|� || j|< || j|< || j|< d S )Nz(attempt to add_indom with an existing ID)r3 r^ rr rs r_ r` ra )r& r# ru rv Zindomid�entryr r r � add_indome s
zMetricDispatch.add_indomc C sj t |t�r|j}|}n|}t||�}t |t�r\x,t| j�D ] \}}|j|kr:|| j|< P q:W || j|< d S )N)rG r2 r3 �list� enumerater^ r_ )r& r# r8 r3 Z replacementr> r{ r r r �
replace_indomo s
z MetricDispatch.replace_indomc C s@ | j | }|jdk r<t� }tj||dt|��}|tjkr<|S dS )z�
Lookup the value associated with an (internal) instance ID
within a specific instance domain (only valid with indoms
of cache type - array indom will always return None).
r N)r_ r4 r
r r@ r r: rA )r& r# rE r{ rC rF r r r � inst_lookup� s
zMetricDispatch.inst_lookupc C s | j | }|j|�S )zv
Lookup the name associated with an (internal) instance ID within
a specific instance domain.
)r_ r; )r& r# rE r{ r r r r; � s
z MetricDispatch.inst_name_lookupc C s4 y| j tj||� }W n tk
r. d}Y nX |S )zR
Lookup the name associated with a performance metric identifier.
N)rd r: � pmda_pmidrr )r& �cluster�itemr1 r r r �pmid_name_lookup� s
z MetricDispatch.pmid_name_lookupN)rq rq )rq rq )r( r) r* r+ r rl rm rn ro rp rw rz r| r r� r; r� r r r r r] � s
r] c @ s� e Zd ZdZdd� Zdd� Zeeddd�Zeeddd�ZdGdd�Z d d
� Z
d d � Z d
d� Z dd� Z
dd� Zedd� �Zedd� �Zedd� �Zedd� �Zedd � �Zed d � �Zed d � �Zed!d"� �Zed#d$� �Zed%d&� �Zed'd(� �Zed)d*� �Zed+d,� �Z ed-d.� �Z ed/d0� �Z ed1d2� �Z ed3d4� �Z ed5d6� �Z!ed7d8� �Z"ed9d:� �Z#ed;d<� �Z$ed=d>� �Z%ed?d@� �Z&edAdB� �Z'edCdD� �Z(edEdF� �Z)dS )H�PMDAzj Defines a PCP performance metrics domain agent
Used to add new metrics into the PCP toolkit.
c C s | j S )z Property for name of this PMDA )�_name)r& r r r � read_name� s zPMDA.read_namec C s | j S )z0 Property for unique domain number of this PMDA )�_domain)r& r r r � read_domain� s zPMDA.read_domainNc C sL || _ || _|s|d }d| }|s6dtjd�|f }tj| ||||� d S )Nz.logZpmdaz
%s/%s/helpZ
PCP_PMDAS_DIR)r� r� �PCPZ pmGetConfigr] r )r& r1 rh ri rj Zpmdanamer r r r � s z
PMDA.__init__c C s t d| jj� | jf � dS )zH
Write out the domain.h file (used during installation)
z
#define %s %dN)�printr� �upperr� )r& r r r � domain_write� s zPMDA.domain_writec sf | j � � fdd�� D �}|dk}d}|r4d}td� x |D ]}td||| jf � q:W |rbtd� d S )
zI
Write out the namespace file (used during installation)
c s h | ]}� | j d �d �qS )�.r )�split)�.0rS )�pmnsr r � <setcomp>� s z"PMDA.pmns_write.<locals>.<setcomp>�rootrq � zroot {z %s%s %d:*:*�}N)rd r� r� )r& r� �prefixes�indentZlead�prefixr )r� r �
pmns_write� s
zPMDA.pmns_writec C s t j� dS )zF
Tell PMCD the PMDA is not ready to process requests.
N)r: �
pmda_notready)r& r r r r� � s zPMDA.pmda_notreadyc C s t j� dS )zB
Tell PMCD the PMDA is ready to process requests.
N)r: �
pmda_ready)r& r r r r� � s zPMDA.pmda_readyc C s| dt jkr| j� nddt jkr0| jt jd � nH| j� tj| j� tj| j � tj
| j � tj | j
� tj| j| j� dS )a�
All the real work happens herein; we can be called in one of three
situations, determined by environment variables. First couple are
during the agent Install process, where the domain.h and namespace
files need to be created. The third case is the real mccoy, where
an agent is actually being started by pmcd/dbpmda and makes use of
libpcp_pmda to talk PCP protocol.
ZPCP_PYTHON_DOMAINZPCP_PYTHON_PMNSN)�os�environr� r� ro r: Zpmid_oneline_refreshrf Zpmid_longtext_refreshrg Zindom_oneline_refreshr` Zindom_longtext_refreshra Z
pmda_dispatchr^ rb )r& r r r �run� s
zPMDA.runc C s
t j| �S )N)r: � set_fetch)Zfetchr r r r� s zPMDA.set_fetchc C s
t j| �S )N)r: � set_label)r r r r r� s zPMDA.set_labelc C s
t j| �S )N)r: � set_notes)Znotesr r r r� s zPMDA.set_notesc C s
t j| �S )N)r: � set_refresh)Zrefreshr r r r�
s zPMDA.set_refreshc C s
t j| �S )N)r: � set_instance)rE r r r r� s zPMDA.set_instancec C s
t j| �S )N)r: �set_fetch_callback)Zfetch_callbackr r r r� s zPMDA.set_fetch_callbackc C s
t j| �S )N)r: �set_label_callback)Zlabel_callbackr r r r� s zPMDA.set_label_callbackc C s
t j| �S )N)r: �set_notes_callback)Znotes_callbackr r r r� s zPMDA.set_notes_callbackc C s
t j| �S )N)r: �set_attribute_callback)Zattribute_callbackr r r r� ! s zPMDA.set_attribute_callbackc C s
t j| �S )N)r: �set_store_callback)Zstore_callbackr r r r� % s zPMDA.set_store_callbackc C s
t j| �S )N)r: �set_endcontext_callback)Zendcontext_callbackr r r r� ) s z PMDA.set_endcontext_callbackc C s
t j| �S )N)r: �set_refresh_all)Z refresh_allr r r r� - s zPMDA.set_refresh_allc C s
t j| �S )N)r: �set_refresh_metrics)Zrefresh_metricsr r r r� 1 s zPMDA.set_refresh_metricsc C s t j� d S )N)r: �set_notify_changer r r r r� 5 s zPMDA.set_notify_changec C s
t j| �S )N)rU ZpmSetProcessIdentity)Zusernamer r r �set_user9 s z
PMDA.set_userc C s t j| |�S )N)r: r� )r� r� r r r r! = s z PMDA.pmidc C s t j| ||�S )N)r: �
pmid_build)rh r� r� r r r r� A s zPMDA.pmid_buildc C s
t j| �S )N)r: � pmid_cluster)r� r r r r� E s zPMDA.pmid_clusterc C s
t j| �S )N)r: Z
pmda_indom)�serialr r r r# I s z
PMDA.indomc C s t j| |�S )N)r: � indom_build)rh r� r r r r� M s zPMDA.indom_buildc C s t j| |||||�S )N)r: Z
pmda_units)Z dim_spaceZdim_timeZ dim_countZ scale_spaceZ
scale_timeZ scale_countr r r r% Q s z
PMDA.unitsc C s
t j| �S )N)r: Z pmda_uptime)Znowr r r �uptimeU s z PMDA.uptimec C s
t j| �S )N)r: Zpmda_set_comm_flags)r r r r �set_comm_flagsY s zPMDA.set_comm_flagsc C s
t j| �S )N)r: Zpmda_log)�messager r r �log] s zPMDA.logc C s
t j| �S )N)r: Zpmda_dbg)r� r r r �dbga s zPMDA.dbgc C s
t j| �S )N)r: Zpmda_err)r� r r r �erre s zPMDA.err)NN)*r( r) r* r+ r� r� �propertyr1 rh r r� r� r� r� r� � staticmethodr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r! r� r� r# r� r% r� r� r� r� r� r r r r r� � sJ
r� )-r+ r� rU r: Z pcp.pmapir r� r r r r r Z ctypes.utilr Zctypesr r
r r r
r r r r r rR ZrestypeZargtypesZpmdaCacheStoreKeyr@ ZpmdaCacheLookupNameZpmdaCacheLookupKeyr9 rZ r r r r r r- r2 r\ �objectr] r� r r r r �<module> sV
r
%