| Server IP : 184.154.167.98 / Your IP : 3.145.50.254 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>�fN� �
@ sz d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl m
Z
m Z m Z m
Z
mZmZ ddl mZmZmZmZmZmZ ddl mZmZmZmZmZ ddl mZm Z m Z m Z m Z ddl m!Z! ee!d��Z"ej#d kr�d
nd Z$ee!e$��Z%ej&d k�re'fZ(e'Z)e*Z+n e'e)fZ(e,Z+d
d� Z-G dd� de.�Z/G dd� de.�Z0ej1dk�rTeZ2n ej1dk�rfeZ2n e/ej3d��ej4dk�r�eZ5n ej4dk�r�eZ5n e/ej3d��G dd� de�Z6G dd� de�Z7G dd � d e�Z8G d d � d e�Z9G d d � d e�Z:G d!d"� d"e�Z;G d#d$� d$e�Z<G d%d&� d&e�Z=G d'd(� d(e�Z>ee>�Z?e@d)d*� ddd�e?_Ae@d+d*� ddd�e?_Be@d,d*� ddd�e?_Ce@d-d*� ddd�e?_DG d.d/� d/e�ZEe ZFe ZGG d0d1� d1e�ZHeeH�ZIe@d2d*� ddd�eI_Je@d3d*� ddd�eI_Ke@d4d*� ddd�eI_Le@d5d*� ddd�eI_Md6d7� ZNG d8d9� d9e�ZOG d:d;� d;e�ZPG d<d=� d=e�ZQeeQ�ZRe@d>d*� ddd�eR_Se@d?d*� ddd�eR_Te@d@d*� ddd�eR_Ue@dAd*� ddd�eR_Ve@dBd*� ddd�eR_WG dCdD� dDe�ZXe e"jY_Zeeee��ge"jY_[e e"j\_Zeeee��eee ��ge"j\_[e e"j]_Zg e"j]_[e e"j^_Zege"j^_[e e"j__Ze edE ee �ge"j__[e e"j`_Ze eee��ge"j`_[e e"ja_Ze ee�ge"ja_[ede�Zbe e"jc_Zeebge"jc_[e e"jd_Zg e"jd_[e e"je_Zeeee�ge"je_[e e"jf_Zege"jf_[e e"jg_Ze eeH�ge"jg_[e e"jh_Ze ee �eeH�ge"jh_[e e"ji_Ze e ee�ge"ji_[e e"jj_Ze e ee�ge"jj_[e e"jk_Ze eee ��eee��ge"jk_[e e"jl_Ze ege"jl_[e e"jm_Ze e ee�ge"jm_[e e"jn_Ze ege"jn_[e e"jo_Ze ge"jo_[e e"jp_Zg e"jp_[e e"jq_Ze ge"jq_[e e"jr_Zg e"jr_[e e"js_Ze e ee �ge"js_[e e"jt_Ze e ee �ge"jt_[e e"ju_Ze ee6�e ge"ju_[e e"jv_Ze ge"jv_[ee"jw_Ze ee ge"jw_[e e"jx_Zg e"jx_[e e"jy_Zege"jy_[e e"jz_Ze ge"jz_[e e"j{_Zee�ge"j{_[ee8�e"j|_Zee
�ee8�ge"j|_[ee"j}_Zee
�ege"j}_[e e"j~_Ze ee �eeeE��ge"j~_[de"j_ZeeE�ge"j_[e e"j�_ZeeE�ge"j�_[e e"j�_ZeeP�ge"j�_[e e"j�_Zee6�ge"j�_[e e"j�_Ze eee ��eee��ge"j�_[e e"j�_Ze ege"jl_[eGege"j�_[e e"j�_ZeGe ge"j�_[e e"j�_ZeeeE��ge"j�_[ee"j�_Zege"j�_[ee"j�_Ze ee ge"j�_[e e"j�_Ze ee=�e ee9�e ge"j�_[e e"j�_Ze ee9�ee:�ee9�ee:�ge"j�_[ee"j�_Zee:�ee ge"j�_[ee"j�_Zeee ge"j�_[e e"j�_Ze e e ge"j�_[e e"j�_Ze ge"j�_[e e"j�_Ze ge"j�_[e e"j�_Ze ge"j�_[ee"j�_Ze ee ge"j�_[e e"j�_Ze e ge"j�_[e e"j�_Ze ge"j�_[e e"j�_Ze ge"j�_[ee"j�_Ze ee ge"j�_[ee"j�_Ze ee ge"j�_[ee"j�_Zee9�e ee ge"j�_[ee"j�_Ze ee ge"j�_[de"j�_Zee e ee=�e ge"j�_[e e"j�_Zeee6�ee�ge"j�_[e e"j�_Zee eeeeO��ee�ge"j�_[e e"j�_Zg e"j�_[e e"j�_Zege"j�_[de"j�_ZeeE�ge"j�_[e e"j�_Ze eeeX��ge"j�_[e e"j�_Ze eeeX��ge"j�_[e e"j�_Ze eeeX��ge"j�_[e e"j�_Ze eeeX��ge"j�_[e e"j�_Ze eeeX��ge"j�_[e e"j�_Ze eeeX��ge"j�_[e e"j�_ZeeeX��ge"j�_[e e"j�_Zee�e ee ge"j�_[ee eeQ�ee�Z�e e"j�_ZeeeX��e ee e�ege"j�_[de"j�_ZeeX�e ge"j�_[G dFdG� dGe��Z�G dHdI� dIe��Z�e e"j�_Zee�e ege"j�_[e e"j�_Zege"j�_[e e"j�_Zege"j�_[e e"j�_Zege"j�_[e e"j�_Zeeeeee9�e ee �ge"j�_[e e"j�_Zeeeee �ee�ee9�e ee �e ee �ee �g e"j�_[e e"j�_Zeeeeeee7�ee9�e ee �e ee �ee �g e"j�_[e e"j�_Zeee6�ge"j�_[e e"j�_Zege"j�_[G dJdK� dKe��Z�dS )La� Wrapper module for LIBPCP - the core Performace Co-Pilot API
#
# Copyright (C) 2012-2021 Red Hat
# Copyright (C) 2009-2012 Michael T. Werner
#
# 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.
#
# Additional Information:
#
# Performance Co-Pilot Web Site
# https://pcp.io
#
# Performance Co-Pilot Programmer's Guide
# cf. Chapter 3. PMAPI - The Performance Metrics API
#
# EXAMPLE
from pcp import pmapi
import cpmapi as c_api
# Create a pcp class
context = pmapi.pmContext(c_api.PM_CONTEXT_HOST, "local:")
# Get ids for number cpus and load metrics
metric_ids = context.pmLookupName(("hinv.ncpu","kernel.all.load"))
# Get the description of the metrics
descs = context.pmLookupDescs(metric_ids)
# Fetch the current value for number cpus
results = context.pmFetch(metric_ids)
# Extract the value into a scalar value
atom = context.pmExtractValue(results.contents.get_valfmt(0),
results.contents.get_vlist(0, 0),
descs[0].contents.type,
c_api.PM_TYPE_U32)
print "#cpus=", atom.ul
# Get the instance ids for kernel.all.load
inst1 = context.pmLookupInDom(descs[1], "1 minute")
inst5 = context.pmLookupInDom(descs[1], "5 minute")
# Loop through the metric ids
for i in range(results.contents.numpmid):
# Is this the kernel.all.load id?
if (results.contents.get_pmid(i) != metric_ids[1]):
continue
# Extract the kernel.all.load instance
for j in range(results.contents.get_numval(i) - 1):
atom = context.pmExtractValue(results.contents.get_valfmt(i),
results.contents.get_vlist(i, j),
descs[i].contents.type,
c_api.PM_TYPE_FLOAT)
value = atom.f
if results.contents.get_inst(i, j) == inst1:
print "load average 1=",atom.f
elif results.contents.get_inst(i, j) == inst5:
print "load average 5=",atom.f
# ... or, using the fetchgroup interface:
from pcp import pmapi
import cpmapi as c_api
pmfg = pmapi.fetchgroup(c_api.PM_CONTEXT_HOST, "local:")
v = pmfg.extend_item("hinv.ncpu")
vv = pmfg.extend_indom("kernel.all.load", c_api.PM_TYPE_FLOAT)
vvv = pmfg.extend_event("systemd.journal.records", field="systemd.journal.field.string")
t = pmfg.extend_timestamp()
pmfg.fetch()
print("time: %s" % t())
print("number of cpus: %d" % v())
for icode, iname, value in vv():
print("load average %s: %f" % (iname, value()))
for ts, line in vvv():
print("%s : %s" % (ts, line()))
� N)�c_char�c_int�c_uint�c_long�c_char_p�c_void_p)�c_float�c_double�c_int32�c_uint32�c_int64�c_uint64)�CDLL�POINTER� CFUNCTYPE� Structure�Union)� addressof�pointer�sizeof�cast�byref)� find_libraryZpcpZwin32�cZmsvcrt�3c C sb t jdkr:ttjj_tjgtjj_t j
tjj| �ddd�S t tjj _tjgtjj _tjj | �S d S )Nr �rF)�closefd)
�sys�versionr �ctypesZ pythonapiZPyObject_AsFileDescriptor�restypeZ py_object�argtypes�os�fdopenr Z
PyFile_AsFile)�fileObj� r% � /usr/lib64/python3.6/pmapi.py�
pyFileToCFile� s
r' c s< e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Z� ZS ) �pmErrc sB t t| �j|� t|�| _|r8t|d t�r8|d | _nd| _d S )Nr )�superr( �__init__�list�args�
isinstance�int�code)�selfr, )� __class__r% r& r* � s
zpmErr.__init__c C sJ d }yt j| j }W n tk
r( Y nX |d kr:| j� S d|| j� f S )Nz%s %s)�c_apiZ pmErrSymDictr/ �KeyError�message)r0 ZerrSymr% r% r& �__str__� s z
pmErr.__str__c C s^ t jtj�}tj| j|tj�}t|j� �}x.t dt
| j ��D ]}|dt| j | � 7 }q<W |S )N� � ) r �create_string_bufferr2 �PM_MAXERRMSGLEN�LIBPCP�
pmErrStr_rr/ �str�decode�range�lenr, )r0 ZerrStr�result�indexr% r% r& r4 � s z
pmErr.messagec C s t tjtd�jj� �S )N�
pmProgname)r< r �in_dllr: �valuer= )r0 r% r% r& �progname� s zpmErr.prognamec C s | j S )N)r/ )r0 r% r% r& �errno� s z pmErr.errno) �__name__�
__module__� __qualname__r* r5 r4 rE rF �
__classcell__r% r% )r1 r& r( � s
r( c s$ e Zd Z� fdd�Zdd� Z� ZS )�
pmUsageErrc s t t| �j|� t|�| _d S )N)r) rK r* r+ r, )r0 r, )r1 r% r& r* � s zpmUsageErr.__init__c C s< x2t dt| j��D ] }tjt| j| �jd�� qW tj� S )Nr zutf-8) r> r? r, r: �pmprintfr< �encoder2 ZpmUsageMessage)r0 rA r% r% r& r4 � s zpmUsageErr.message)rG rH rI r* r4 rJ r% r% )r1 r& rK � s rK � � zUnexpected suseconds_t sizezUnexpected time_t sizec @ sj e Zd ZdefdefgZddd�Zedd� �Zdd � Z d
d � Z
d d
� Z dd� Z dd� Z
dd� Zdd� ZdS )�timeval�tv_sec�tv_usecr c C s t j| � || _|| _d S )N)r r* rQ rR )r0 �secZusecr% r% r& r* � s
ztimeval.__init__c C sL | � }t � }t|t�s |jd�}tj|t|�t|��}|dk rHt||��|S )z7 Construct timeval from a string using pmParseInterval zutf-8r )r r- �bytesrM r: �pmParseIntervalr r( )�cls�interval�tvp�errmsg�statusr% r% r& � fromInterval� s
ztimeval.fromIntervalc C s dt j| j| j� S )Nz%.3f)r2 �pmtimevalToRealrQ rR )r0 r% r% r& r5 � s ztimeval.__str__c C s t tj| j| j��S )N)�floatr2 r\ rQ rR )r0 r% r% r& � __float__� s ztimeval.__float__c C s t tj| j| j��S )N)�complexr2 r\ rQ rR )r0 r% r% r& � __complex__� s ztimeval.__complex__c C s
t | j�S )N)r. rQ )r0 r% r% r& � __index__ s ztimeval.__index__c C s
t | j�S )N)�longrQ )r0 r% r% r& �__long__ s ztimeval.__long__c C s
t | j�S )N)r. rQ )r0 r% r% r& �__int__ s ztimeval.__int__c C s t jt| �� dS )z9 Delay for the amount of time specified by this timeval. N)�time�sleepr] )r0 r% r% r& rf s z
timeval.sleepN)r r )rG rH rI �c_time_t�
c_suseconds_t�_fields_r* � classmethodr[ r5 r^ r` ra rc rd rf r% r% r% r& rP � s
rP c @ s. e Zd ZdefdefgZd dd�Zdd� ZdS )
�timespecrQ �tv_nsecr c C s t j| � || _|| _d S )N)r r* rQ rl )r0 rS Znsecr% r% r& r* s
ztimespec.__init__c C s dt | j�t | j�d S )Nz%.3fg e��A)r] rQ rl )r0 r% r% r& r5 s ztimespec.__str__N)r r )rG rH rI rg r ri r* r5 r% r% r% r& rk
s
rk c @ sb e Zd Zdefdefdefdefdefdefdefdefd efd
efd efg Zd d
� Zdd� ZdS )�tm�tm_sec�tm_min�tm_hour�tm_mday�tm_mon�tm_year�tm_wday�tm_yday�tm_isdst� tm_gmtoff�tm_zonec C sR | j d }|dk rd}| jd | jd | j| j| j| j|| jd | jg }t j
|�S )Nr6 r � il ) rt rs rr rq rp ro rn ru rv re � struct_time)r0 ZpywdayZstlistr% r% r& rz & s
ztm.struct_timec
C st t jd�}tj| j| j| j| j| j| j | j
| j | j t
| j�t| j�� }tt
|��}tjt|�|� t|jj� �j� S )N� )r r8 r2 ZpmMktimern ro rp rq rr rs rt ru rv rb rw r< rx r r: �pmCtimer rD r= �rstrip)r0 r@ �second�timetpr% r% r& r5 1 s
z
tm.__str__N) rG rH rI r r r ri rz r5 r% r% r% r& rm s
rm c @ s� e Zd ZdZdefdefdefdefdefde fde
fd e fgZ e
jd
d � e
jd d � e
jd
d � e
jdd � e
jdd � e
jdd � e
jdd � e
jdd � e
jdd � e
jdd � e
jdd � e
jdd � e
jdd � i
Zdd� Z dS )� pmAtomValuez�Union used for unpacking metric values according to type
Constants for specifying metric types are defined in module pmapi
�l�ul�ll�ull�f�d�cpZvpc C s | j S )N)r� )�xr% r% r& �<lambda>P s zpmAtomValue.<lambda>c C s | j S )N)r� )r� r% r% r& r� Q s c C s | j S )N)r� )r� r% r% r& r� R s c C s | j S )N)r� )r� r% r% r& r� S s c C s | j S )N)r� )r� r% r% r& r� T s c C s | j S )N)r� )r� r% r% r& r� U s c C s | j S )N)r� )r� r% r% r& r� V s c C s d S )Nr% )r� r% r% r& r� W s c C s d S )Nr% )r� r% r% r& r� X s c C s d S )Nr% )r� r% r% r& r� Y s c C s d S )Nr% )r� r% r% r& r� Z s c C s d S )Nr% )r� r% r% r& r� [ s c C s d S )Nr% )r� r% r% r& r� \ s c C sL | j | | �}|tjkrHyt|jd��}W n tk
rF t|�}Y nX |S )Nzutf-8)�
_atomDrefDr2 �PM_TYPE_STRINGr< r= � Exception)r0 �typedrD r% r% r& �dref_ s
zpmAtomValue.drefN) rG rH rI �__doc__r
r r r
r r r r ri r2 Z
PM_TYPE_32Z PM_TYPE_U32Z
PM_TYPE_64Z PM_TYPE_U64Z
PM_TYPE_FLOATZPM_TYPE_DOUBLEr� ZPM_TYPE_AGGREGATEZPM_TYPE_AGGREGATE_STATICZ
PM_TYPE_EVENTZPM_TYPE_HIGHRES_EVENTZPM_TYPE_NOSUPPORTZPM_TYPE_UNKNOWNr� r� r% r% r% r& r� B s.
r� c @ s� e Zd ZdZejrPdedfdedfdedfdedfdedfdedfd ed
fgZn<d ed
fdedfdedfdedfdedfdedfdedfgZdd d
�Zdd� Z dd� Z
dS )�pmUnitsz�
Compiler-specific bitfields specifying scale and dimension of metric values
Constants for specifying metric units are defined in module pmapi
IRIX => HAVE_BITFIELDS_LTOR, gcc => not so much
�dimSpacerN �dimTime�dimCount�
scaleSpace� scaleTime�
scaleCount�padrO r c C s8 t j| � || _|| _|| _|| _|| _|| _d| _d S )Nr ) r r* r� r� r� r� r� r� r� )r0 ZdimSZdimTZdimCZscaleSZscaleTZscaleCr% r% r& r* s
zpmUnits.__init__c C s t j| j| j| j| j| j| j�S )N)r2 Z pmUnits_intr� r� r� r� r� r� )r0 r% r% r& rd � s zpmUnits.__int__c C s$ t jd�}tj| |d�}t|j� �S )N�@ )r r8 r: � pmUnitsStr_rr< r= )r0 �unitstrr@ r% r% r& r5 � s
zpmUnits.__str__N)r r r r r r ) rG rH rI r� r2 �HAVE_BITFIELDS_LTORr ri r* rd r5 r% r% r% r& r� h s&
r� c @ sT e Zd ZdZejr2dedfdedfded fgZn dedfdedfded fgZdS ) � pmValueBlockz�Value block bitfields for different compilers
A value block holds the value of an instance of a metric
pointed to by the pmValue structure, when that value is
too large (> 32 bits) to fit in the pmValue structure
ZvtyperO Zvlen� Zvbufr6 N) rG rH rI r� r2 r� r r ri r% r% r% r& r� � s r� c @ s, e Zd ZdZdee�fdefgZdd� ZdS )� valueDrefz�Union in pmValue for dereferencing the value of an instance of a metric
For small items, e.g. a 32-bit number, the union contains the actual value
For large items, e.g. a text string, the union points to a pmValueBlock
�pval�lvalc C s
d| j S )Nz
value=%#lx)r� )r0 r% r% r& r5 � s zvalueDref.__str__N) rG rH rI r� r r� r ri r5 r% r% r% r& r� � s
r� c @ s( e Zd ZdZdefdefgZdd� ZdS )�pmValuez1Structure holding the value of a metric instance �instrD c C s t | j�}dt| �| jf | S )NzpmValue@%#lx inst=%d )r< rD r r� )r0 �vstrr% r% r& r5 � s
zpmValue.__str__N)rG rH rI r� r r� ri r5 r% r% r% r& r� � s
r� c @ sN e Zd ZdZdefdefdefded fgZdd� Zd d
� Z e
e d d d �Z d S ) �
pmValueSeta� Structure holding a metric's list of instance values
A performance metric may contain one or more instance values, one for each
item that the metric concerns. For example, a metric measuring filesystem
free space would contain one instance value for each filesystem that exists
on the target machine. Whereas, a metric measuring free memory would have
only one instance value, representing the total amount of free memory on
the target system.
�pmid�numval�valfmt�vlistr6 c sT � j dkrLt� j�}t� fdd�|D ��}t� �� j� j� j f}d| | S dS d S )Nr c s g | ]}d t � j| � �qS )z %s)r< r� )�.0�i)r0 r% r& �
<listcomp>� s z&pmValueSet.__str__.<locals>.<listcomp>z+pmValueSet@%#lx id=%#lx numval=%d valfmt=%d� )r� r> r� r< r r� )r0 �valsr� �vsetr% )r0 r& r5 � s
zpmValueSet.__str__c C s t | jd �S )Nr )r Z_vlist)r0 r% r% r& �
vlist_read� s zpmValueSet.vlist_readN) rG rH rI r� r r r� ri r5 r� �propertyr� r% r% r% r& r� � s r� c C s | j jS )N)�contentsr� )r� r% r% r& r� � s r� c C s | j jS )N)r� r� )r� r% r% r& r� � s c C s | j jS )N)r� r� )r� r% r% r& r� � s c C s | j jS )N)r� r� )r� r% r% r& r� � s c @ sn e Zd ZdZdefdefdee�d fgZdd� Z dd � Z
d
d � Z d d
� Z dd� Z
dd� Zdd� Zdd� ZdS )�pmResultz�Structure returned by pmFetch, with a value set for each metric queried
The vset is defined with a "fake" array bounds of 1, which can give runtime
array bounds complaints. The getter methods are array bounds agnostic.
Z timestamp�numpmidr� r6 c C s t j| � d| _d S )Nr )r r* r� )r0 r% r% r& r* � s
zpmResult.__init__c s6 t � j�}t� fdd�|D ��}dt� �� jf | S )Nc s g | ]}d t � j| j� �qS )z %s)r< r� r� )r� r� )r0 r% r& r� � s z$pmResult.__str__.<locals>.<listcomp>zpmResult@%#lx id#=%d )r> r� r< r )r0 r� r� r% )r0 r& r5 � s
zpmResult.__str__c C s t | jtt��}|| jjS )z# Return the pmid of vset[vset_idx] )r r� r �
pmValueSetPtrr� r� )r0 �vset_idx�vsetptrr% r% r& �get_pmid� s zpmResult.get_pmidc C s t | jttt���}|| jjS )z% Return the valfmt of vset[vset_idx] )r r� r r� r� r� )r0 r� r� r% r% r& �
get_valfmt� s zpmResult.get_valfmtc C s t | jttt���}|| jjS )z% Return the numval of vset[vset_idx] )r r� r r� r� r� )r0 r� r� r% r% r& �
get_numval� s zpmResult.get_numvalc C s t | jttt���}|| S )z Return the vset[vset_idx] )r r� r r� )r0 r� r� r% r% r& �get_vset� s zpmResult.get_vsetc C s t | j|�jjtt��}|| S )z/ Return the vlist[vlist_idx] of vset[vset_idx] )r r� r� r� r r� )r0 r� � vlist_idxZlistptrr% r% r& � get_vlist s zpmResult.get_vlistc C s | j ||�jS )z8 Return the inst for vlist[vlist_idx] of vset[vset_idx] )r� r� )r0 r� r� r% r% r& �get_inst s zpmResult.get_instN)rG rH rI r� rP r r r� ri r* r5 r� r� r� r� r� r� r% r% r% r& r� � s r� c @ s: e Zd ZdZdefdefdefdefdefgZdd� Zd S )
�pmDescz"Structure describing a metric
r� �type�indom�sem�unitsc C s t | �| j| jf}d| S )NzpmDesc@%#lx id=%#lx type=%d)r r� r� )r0 �fieldsr% r% r& r5 s zpmDesc.__str__N) rG rH rI r� r r r� ri r5 r% r% r% r& r� s
r� c C s | j jS )N)r� r� )r� r% r% r& r� s c C s | j jS )N)r� r� )r� r% r% r& r� s c C s | j jS )N)r� r� )r� r% r% r& r� s c C s | j jS )N)r� r� )r� r% r% r& r� s c C s< G dd� dt �}t| tt��r&| jjS |� }| |_|jS dS )z�Internal function to extract an indom from a pmdesc
Allow functions requiring an indom to be passed a pmDesc* instead
c @ s e Zd Zdee�fdefgZdS )zget_indom.<locals>.Valuer� r� N)rG rH rI r r� r ri r% r% r% r& �Value$ s
r� N)r r- r r� r� r� r� r� )�pmdescr� rD r% r% r& � get_indom s r� c @ sL e Zd ZdZdefdefdefdefdee�fgZdd� Ze dd d ��Z
d
S )� pmMetricSpecz.Structure describing a metric's specification �isarch�source�metric�ninstr� c s8 t t� fdd�t� j���}t� �� j� j|f}d| S )Nc s t � j| �S )N)r< r� )r� )r0 r% r& r� 7 s z&pmMetricSpec.__str__.<locals>.<lambda>z+pmMetricSpec@%#lx src=%s metric=%s insts=%s)r+ �mapr> r� r r� r� )r0 Zinstsr� r% )r0 r& r5 6 s zpmMetricSpec.__str__r r� c C sh t | �� }t� }t|t�s$|jd�}t|t�s8|jd�}tj|||t|�t|��}|dk rdt||��|S )Nzutf-8r ) r r r- rT rM r: �pmParseMetricSpecr r( )rV �stringr� r� r@ rY rZ r% r% r& �
fromString; s
zpmMetricSpec.fromStringN)r r� ) rG rH rI r� r r r ri r5 rj r� r% r% r% r& r� / s r� c @ sN e Zd ZdZdefdefdefdeej fdeej fgZ
dd� Z d d
� Z d S ) �
pmLogLabelz,Label record at the start of every log file �magicZpid_t�start�hostname�tzc C s t | jj� �S )z6 Return the hostname from the structure as native str )r< r� r= )r0 r% r% r& � get_hostnameQ s zpmLogLabel.get_hostnamec C s t | jj� �S )z6 Return the timezone from the structure as native str )r< r� r= )r0 r% r% r& � get_timezoneU s zpmLogLabel.get_timezoneN)
rG rH rI r� r rP r r2 �PM_LOG_MAXHOSTLENZ PM_TZ_MAXLENri r� r� r% r% r% r& r� I s r� c @ sD e Zd ZdZdedfdedfdedfdedfdedfgZd d
� Zd S ) �pmLabelz*Structure describing label's specification�name� �namelenrO �flagsrD �valuelenc C s | j d d | j d S )N�:�")r� rD )r0 r% r% r& r5 ` s zpmLabel.__str__N)rG rH rI r� r ri r5 r% r% r% r& r� Y s r� c C s | j jS )N)r� r� )r� r% r% r& r� d s c C s | j jS )N)r� r� )r� r% r% r& r� e s c C s | j jS )N)r� r� )r� r% r% r& r� f s c C s | j jS )N)r� rD )r� r% r% r& r� g s c C s | j jS )N)r� r� )r� r% r% r& r� h s c @ sV e Zd ZdZdefdefdefdedfdedfd ed
fd ee�fd e fgZ
d
d� Z dS )�
pmLabelSetz. Structure describing label set specificationsr� Znlabels�json�jsonlenr� Zpadding� Zcompoundr6 �labels�hashc C s | j d krdS | j j� S )Nz{})r� r= )r0 r% r% r& r5 t s
zpmLabelSet.__str__N) rG rH rI r� r r r r r� r ri r5 r% r% r% r& r� j s
r� r6 c @ sh e Zd ZdZdd� Zdd� Zdd� Zdd � Zeed
d
d
�Z eed
d
d
�Z
eeed
d
�Z d�d d
�Z dd� Z
edd� �Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Z d,d-� Z d.d/� Z d0d1� Z d2d3� Z d4d5� Z!d6d7� Z"d8d9� Z#d:d;� Z$d<d=� Z%d>d?� Z&d@dA� Z'dBdC� Z(dDdE� Z)dFdG� Z*dHdI� Z+dJdK� Z,dLdM� Z-dNdO� Z.dPdQ� Z/dRdS� Z0dTdU� Z1dVdW� Z2dXdY� Z3dZd[� Z4d\d]� Z5d^d_� Z6d`da� Z7dbdc� Z8ddde� Z9dfdg� Z:dhdi� Z;djdk� Z<dldm� Z=dndo� Z>dpdq� Z?drds� Z@dtdu� ZAdvdw� ZBdxdy� ZCdzd{� ZDd|d}� ZEd~d� ZFd�d�� ZGd�d�� ZHd�d�� ZId�d�� ZJd�d�� ZKd�d�� ZLd�d�� ZMd
S )�� pmOptionsz� Command line option parsing for short and long form arguments
Passed into pmGetOptions, pmGetContextOptions, pmUsageMessage.
c C s | j S )N)�_mode)r0 r% r% r& �_R_mode� s zpmOptions._R_modec C s | j S )N)�_delta)r0 r% r% r& �_R_delta� s zpmOptions._R_deltac C s | j S )N)� _need_reset)r0 r% r% r& �
_R_need_reset� s zpmOptions._R_need_resetc C s
|| _ d S )N)r� )r0 rD r% r% r& �
_W_need_reset� s zpmOptions._W_need_resetNr c C sd t j� |d k rt j|� |d k r,t j|� |dkr@t j|� n t jt j� d| _t j| _d| _ d S )Nr r6 F)
r2 �pmResetAllOptions�pmSetShortOptions�pmSetShortUsage�pmSetOptionFlagsZPM_OPTFLAG_BOUNDARIESr� �PM_MODE_INTERPr� r� )r0 �
short_options� short_usager� r% r% r& r* � s
zpmOptions.__init__c C s t d k r| jrtj� d S )N)r: r� r2 r� )r0 r% r% r& �__del__� s zpmOptions.__del__c C s t j� S )z> Cross-platform --daemonize (re-parent to init) option helper )r2 Z
pmServerStartr% r% r% r& � daemonize� s zpmOptions.daemonizec C s t j� S )N)r2 �pmGetOptionFlags)r0 r% r% r& r� � s zpmOptions.pmGetOptionFlagsc C s
t j|�S )N)r2 �pmSetOptionContext)r0 �contextr% r% r& r� � s z pmOptions.pmSetOptionContextc C s
t j|�S )N)r2 r� )r0 r� r% r% r& r� � s zpmOptions.pmSetOptionFlagsc C s t j� S )N)r2 �pmGetOptionErrors)r0 r% r% r& r� � s zpmOptions.pmGetOptionErrorsc C s t j� d }t j|�S )Nr6 )r2 r� �pmSetOptionErrors)r0 �errorsr% r% r& r� � s zpmOptions.pmSetOptionErrorsc C s
t j|�S )N)r2 r� )r0 r� r% r% r& r� � s zpmOptions.pmSetShortUsagec C s
t j|�S )N)r2 r� )r0 r� r% r% r& r� � s zpmOptions.pmSetShortOptionsc C s
t j|�S )z/ Set sample count (converts string to integer) )r2 �pmSetOptionSamples)r0 �countr% r% r& r� � s z pmOptions.pmSetOptionSamplesc C s
t j|�S )z0 Set sampling interval (pmParseInterval string) )r2 �pmSetOptionInterval)r0 rW r% r% r& r� � s z pmOptions.pmSetOptionIntervalc C s t j� S )a! After a pmGetOptions(3) call has been made this method
returns a list of any remaining parameters which were
not parsed as command line options, aka "operands".
http://pubs.opengroup.org/onlinepubs/009695399/basedefs/xbd_chap03.html#tag_03_254
)r2 �
pmGetOperands)r0 r% r% r& r � s zpmOptions.pmGetOperandsc C s
t j|�S )N)r2 �pmGetNonOptionsFromList)r0 �argvr% r% r& r � s z!pmOptions.pmGetNonOptionsFromListc C s
t j|�S )N)r2 r )r0 r r% r% r& �pmNonOptionsFromList� s z pmOptions.pmNonOptionsFromListc C s
t j|�S )a� Handle individual command line options, outside of the PCP
"standard" set (or overridden).
For every non-standard or overridden option, this callback
will be called with the short option character (as an int)
or zero for long-option only, and the usual getopts global
state (optind, opterr, optopt, optarg, and index - all int
except optarg which is a str).
)r2 �pmSetOptionCallback)r0 �funcr% r% r& r � s
z pmOptions.pmSetOptionCallbackc C s
t j|�S )az Allow a "standard" PCP option to be overridden.
For every option parsed, this callback is called and it may
return zero, meaning continue with processing the option in
the standard way, or non-zero, meaning the caller wishes to
override and interpret the option differently.
Callback input: int, output: int
)r2 �pmSetOverrideCallback)r0 r r% r% r& r s z pmOptions.pmSetOverrideCallbackc C s |dkr d}t j|||||�S )a& Add long option into the set of supported long options
Pass in the option name (str), whether it takes an argument (int),
its short option form (str), and two usage message hints (argname
(str) and message (str) - see pmGetOptions(3) for details).
Nr� )r2 �pmSetLongOption)r0 Zlong_optZhas_argZ short_optZargnamer4 r% r% r& r s zpmOptions.pmSetLongOptionc C s
t j|�S )z> Add a new section heading into the long option usage message )r2 �pmSetLongOptionHeader)r0 Zheadingr% r% r& r s z pmOptions.pmSetLongOptionHeaderc C s
t j|�S )z> Add some descriptive text into the long option usage message )r2 �pmSetLongOptionText)r0 �textr% r% r& r # s z pmOptions.pmSetLongOptionTextc C s t j� S )z4 Add support for -A/--align into PMAPI monitor tool )r2 �pmSetLongOptionAlign)r0 r% r% r& r ' s z pmOptions.pmSetLongOptionAlignc C s t j� S )z6 Add support for -a/--archive into PMAPI monitor tool )r2 �pmSetLongOptionArchive)r0 r% r% r& r + s z pmOptions.pmSetLongOptionArchivec C s t j� S )z4 Add support for -D/--debug into PMAPI monitor tool )r2 �pmSetLongOptionDebug)r0 r% r% r& r
/ s z pmOptions.pmSetLongOptionDebugc C s dS )z Unimplemented Nr% )r0 r% r% r& �pmSetLongOptionGuiMode3 s z pmOptions.pmSetLongOptionGuiModec C s t j� S )z3 Add support for -h/--host into PMAPI monitor tool )r2 �pmSetLongOptionHost)r0 r% r% r& r 7 s z pmOptions.pmSetLongOptionHostc C s t j� S )z8 Add support for -H/--hostsfile into PMAPI monitor tool )r2 �pmSetLongOptionHostsFile)r0 r% r% r& r ; s z"pmOptions.pmSetLongOptionHostsFilec C s t j� S )z9 Add support for -K/--spec-local into PMAPI monitor tool )r2 �pmSetLongOptionSpecLocal)r0 r% r% r& r ? s z"pmOptions.pmSetLongOptionSpecLocalc C s t j� S )z9 Add support for -L/--local-PMDA into PMAPI monitor tool )r2 �pmSetLongOptionLocalPMDA)r0 r% r% r& r C s z"pmOptions.pmSetLongOptionLocalPMDAc C s t j� S )z5 Add support for -O/--origin into PMAPI monitor tool )r2 �pmSetLongOptionOrigin)r0 r% r% r& r G s z pmOptions.pmSetLongOptionOriginc C s dS )z Unimplemented Nr% )r0 r% r% r& �pmSetLongOptionGuiPortK s z pmOptions.pmSetLongOptionGuiPortc C s t j� S )z4 Add support for -S/--start into PMAPI monitor tool )r2 �pmSetLongOptionStart)r0 r% r% r& r O s z pmOptions.pmSetLongOptionStartc C s t j� S )z6 Add support for -s/--samples into PMAPI monitor tool )r2 �pmSetLongOptionSamples)r0 r% r% r& r S s z pmOptions.pmSetLongOptionSamplesc C s t j� S )z5 Add support for -T/--finish into PMAPI monitor tool )r2 �pmSetLongOptionFinish)r0 r% r% r& r W s z pmOptions.pmSetLongOptionFinishc C s t j� S )z7 Add support for -t/--interval into PMAPI monitor tool )r2 �pmSetLongOptionInterval)r0 r% r% r& r [ s z!pmOptions.pmSetLongOptionIntervalc C s t j� S )z6 Add support for -V/--version into PMAPI monitor tool )r2 �pmSetLongOptionVersion)r0 r% r% r& r _ s z pmOptions.pmSetLongOptionVersionc C s t j� S )z7 Add support for -Z/--timezone into PMAPI monitor tool )r2 �pmSetLongOptionTimeZone)r0 r% r% r& r c s z!pmOptions.pmSetLongOptionTimeZonec C s t j� S )z7 Add support for -z/--hostzone into PMAPI monitor tool )r2 �pmSetLongOptionHostZone)r0 r% r% r& r g s z!pmOptions.pmSetLongOptionHostZonec C s t j� S )z3 Add support for -?/--help into PMAPI monitor tool )r2 �pmSetLongOptionHelp)r0 r% r% r& r k s z pmOptions.pmSetLongOptionHelpc C s t j� S )z8 Add support for --archive-list into PMAPI monitor tool )r2 �pmSetLongOptionArchiveList)r0 r% r% r& r o s z$pmOptions.pmSetLongOptionArchiveListc C s t j� S )z9 Add support for --archive-folio into PMAPI monitor tool )r2 �pmSetLongOptionArchiveFolio)r0 r% r% r& r s s z%pmOptions.pmSetLongOptionArchiveFolioc C s t j� S )z5 Add support for --container into PMAPI monitor tool )r2 �pmSetLongOptionContainer)r0 r% r% r& r w s z"pmOptions.pmSetLongOptionContainerc C s t j� S )z5 Add support for --host-list into PMAPI monitor tool )r2 �pmSetLongOptionHostList)r0 r% r% r& r { s z!pmOptions.pmSetLongOptionHostListc C s t j� S )N)r2 �pmGetOptionContext)r0 r% r% r& r! s z pmOptions.pmGetOptionContextc C s t j� S )N)r2 �pmGetOptionHosts)r0 r% r% r& r" � s zpmOptions.pmGetOptionHostsc C s t j� S )N)r2 �pmGetOptionArchives)r0 r% r% r& r# � s z pmOptions.pmGetOptionArchivesc C s t j� }|d krd S tj|�S )N)r2 �pmGetOptionAlign_optargrP r[ )r0 Z alignmentr% r% r& �pmGetOptionAlignment� s z pmOptions.pmGetOptionAlignmentc C s" t j� }|d krd S t|t j� �S )N)r2 ZpmGetOptionStart_secrP ZpmGetOptionStart_usec)r0 rS r% r% r& �pmGetOptionStart� s zpmOptions.pmGetOptionStartc C s t j� S )N)r2 r$ )r0 r% r% r& �pmGetOptionAlignOptarg� s z pmOptions.pmGetOptionAlignOptargc C s t j� S )N)r2 ZpmGetOptionFinish_optarg)r0 r% r% r& �pmGetOptionFinishOptarg� s z!pmOptions.pmGetOptionFinishOptargc C s" t j� }|d krd S t|t j� �S )N)r2 ZpmGetOptionFinish_secrP ZpmGetOptionFinish_usec)r0 rS r% r% r& �pmGetOptionFinish� s zpmOptions.pmGetOptionFinishc C s" t j� }|d krd S t|t j� �S )N)r2 ZpmGetOptionOrigin_secrP ZpmGetOptionOrigin_usec)r0 rS r% r% r& �pmGetOptionOrigin� s zpmOptions.pmGetOptionOriginc C s" t j� }|d krd S t|t j� �S )N)r2 ZpmGetOptionInterval_secrP ZpmGetOptionInterval_usec)r0 rS r% r% r& �pmGetOptionInterval� s z pmOptions.pmGetOptionIntervalc C s t j� S )N)r2 �pmGetOptionSamples)r0 r% r% r& r, � s z pmOptions.pmGetOptionSamplesc C s t j� dkrdS dS )Nr FT)r2 �pmGetOptionHostZone)r0 r% r% r& r- � s z pmOptions.pmGetOptionHostZonec C s t j� S )N)r2 �pmGetOptionTimezone)r0 r% r% r& r. � s z pmOptions.pmGetOptionTimezonec C s t j� S )N)r2 �pmGetOptionContainer)r0 r% r% r& r/ � s z pmOptions.pmGetOptionContainerc C s t j� dkrdS dS )Nr FT)r2 �pmGetOptionLocalPMDA)r0 r% r% r& r0 � s z pmOptions.pmGetOptionLocalPMDAc C s
t j|�S )N)r2 �pmSetOptionArchive)r0 �archiver% r% r& r1 � s z pmOptions.pmSetOptionArchivec C s
t j|�S )N)r2 �pmSetOptionArchiveList)r0 �archivesr% r% r& r3 � s z pmOptions.pmSetOptionArchiveListc C s
t j|�S )N)r2 �pmSetOptionArchiveFolio)r0 Zfolior% r% r& r5 � s z!pmOptions.pmSetOptionArchiveFolioc C s
t j|�S )N)r2 �pmSetOptionContainer)r0 Z containerr% r% r& r6 � s z pmOptions.pmSetOptionContainerc C s
t j|�S )N)r2 �pmSetOptionHost)r0 �hostr% r% r& r7 � s zpmOptions.pmSetOptionHostc C s
t j|�S )N)r2 �pmSetOptionHostList)r0 �hostsr% r% r& r9 � s z pmOptions.pmSetOptionHostListc C s
t j|�S )N)r2 �pmSetOptionSpecLocal)r0 �specr% r% r& r; � s z pmOptions.pmSetOptionSpecLocalc C s t j� S )N)r2 �pmSetOptionLocalPMDA)r0 r% r% r& r= � s z pmOptions.pmSetOptionLocalPMDA)NNr )NrG rH rI r� r� r� r� r� r� �mode�delta�
need_resetr* 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 r r r r r r r r r r! r" r# r% r& r' r( r) r* r+ r, r- r. r/ r0 r1 r3 r5 r6 r7 r9 r; r= r% r% r% r& r� � s�
r� c @ s e Zd ZdZdd� Zdd� Zdd� Zeeddd�Zeeddd�Z eeddd�Z
e j d fd
d �Z
d d
� Zed�dd��Zedd� �Zdd� Zdd� Zdd� Zdd� Zd�dd �Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Z d'd(� Z ed)d*� �Z d+d,� Z d-d.� Z e j!fd/d0�Z"e j!fd1d2�Z#d�d3d4�Z$d5d6� Z%d7d8� Z&d9d:� Z'd;d<� Z(d=d>� Z)d?d@� Z*dAdB� Z+edCdD� �Z,dEdF� Z-dGdH� Z.dIdJ� Z/dKdL� Z0dMdN� Z1dOdP� Z2edQdR� �Z3edSdT� �Z4edUdV� �Z5dWdX� Z6dYdZ� Z7d[d\� Z8ed]d^� �Z9d_d`� Z:dadb� Z;dcdd� Z<dedf� Z=dgdh� Z>didj� Z?dkdl� Z@d�dndo�ZAdpdq� ZBdrds� ZCdtdu� ZDdvdw� ZEdxdy� ZFdzd{� ZGd|d}� ZHed~d� �ZIed�d�d���ZJed�d�d���ZKed�d�� �ZLed�d�� �ZMed�d�� �ZNed�d�� �ZOed�d�� �ZPed�d�� �ZQed�d�� �ZRed�d�� �ZSed�d�� �ZTed�d�� �ZUed�d�� �ZVed�d�� �ZWed�d�� �ZXed�d�� �ZYed�d�� �ZZed�d�� �Z[ed�d�� �Z\ed�d�� �Z]ed�d�� �Z^ed�d�� �Z_ed�d�� �Z`ed�d�� �Zaed�d�� �Zbed�d�d���Zced�d�� �Zded�d�� �Zeed�d�� �Zfed�d�� �Zged�d�d���Zhed�d�� �Zied�dÄ �Zjee jkfd�dń�Zled�dDŽ �Zmd�dɄ ZndS )�� pmContexta� Defines a metrics source context (e.g. host, archive, etc) to operate on
pmContext(c_api.PM_CONTEXT_HOST,"local:")
pmContext(c_api.PM_CONTEXT_ARCHIVE,"FILENAME")
This object defines a PMAPI context, and its methods wrap calls to PMAPI
library functions. Detailled information about those C library functions
can be found in the following document.
SGI Document: 007-3434-005
Performance Co-Pilot Programmer's Guide
Section 3.7 - PMAPI Procedural Interface, pp. 67
Detailed information about the underlying data structures can be found
in the same document.
Section 3.4 - Performance Metric Descriptions, pp. 59
Section 3.5 - Performance Metric Values, pp. 62
c C s | j S )N)�_type)r0 r% r% r& �_R_type� s zpmContext._R_typec C s | j S )N)�_target)r0 r% r% r& � _R_target� s zpmContext._R_targetc C s | j S )N)�_ctx)r0 r% r% r& �_R_ctx� s zpmContext._R_ctxNzlocal:c C s^ || _ || _tj| _|r0t|t� r0|jd�}n|}tj ||�| _| jdk rZt
| j|g��d S )Nzutf-8r ) rC rE r2 �PM_ERR_NOCONTEXTrG r- rT rM r: � pmNewContextr( )r0 r� �targetr� r% r% r& r* s
zpmContext.__init__c C s$ t d k r | jtjkr t j| j� d S )N)r: rG r2 rI �pmDestroyContext)r0 r% r% r& r� s zpmContext.__del__r c C s� |dks|dkr,d|_ tj|�r$t�|j� }|tjkrH|j� }|| }nZ|tjkrd|j� }|| }n>|tj krtd}n.|j
� dk r�|j� }|| }tj}n
tj}d}| ||�}tj |j |j
|j�r�t�|S )a� Helper interface, simple PCP monitor argument parsing.
Take argv list, create a context using pmGetOptions(3)
and standard options default values like local: etc
based on the contents of the list.
Caller should have already registered any options of
interest using the option family of interfaces, i.e.
pmSetShortOptions, pmSetLongOption*, pmSetOptionFlags,
pmSetOptionCallback, and pmSetOptionOverrideCallback.
When the MULTI/MIXED pmGetOptions flags are being used,
the typed/index parameters can be used to setup several
contexts based on the given command line parameters.
Nr Tzlocal:)r@ r2 ZpmGetOptionsFromListrK r! �PM_CONTEXT_ARCHIVEr# �PM_CONTEXT_HOSTr" �PM_CONTEXT_LOCALr* ZpmSetContextOptions�ctxr> r? ) rV �optionsr r� rA r4 r� r: r� r% r% r& � fromOptions s.
zpmContext.fromOptionsc C s> d}t j� r,t j}| jt j� | j� d }nFt j� rTt j}| jt j� | j� d }n t j� rrt j}| jt j� d}|s�d|kr�t j}| j|� | jt j� nD|dkr�t j}| j |� | jt j� n t j}| j
� | jt j� d}|t jko�|�rx$t d|j d��D ]}| j
|� �qW | j� }| j|t jB � t j� ||fS )zF Helper to set connection options and to get context/source for pmfg. Nr �/�@�;)r2 r# rM r� r" rN r0 rO r1 r7 r= �filter�splitr; r� r� ZPM_OPTFLAG_DONEZ pmEndOptions)rQ r� Z speclocalr� r< r� r% r% r& �set_connect_optionsK sB
z pmContext.set_connect_optionsc s� t t�� � tj| j�}|dk r&t|��t|t�s:|jd�}tj |t
� ��}|dk rZt|��|dkr�t t � fdd�t
|���}tj� � ndS |S )zsPMAPI - Return names of children of the given PMNS node NAME
tuple names = pmGetChildren("kernel")
r zutf-8c s t � | j� �S )N)r< r= )r� )� offspringr% r& r� � s z)pmContext.pmGetChildren.<locals>.<lambda>N)r r r: � pmUseContextrP r( r- rT rM �
pmGetChildrenr r+ r� r> �LIBC�free)r0 r� rZ �childLr% )rY r& r[ z s
zpmContext.pmGetChildrenc s� t t�� �t t�� � tj| j�}|dk r0t|��t|t�sD|j d�}tj
|t ��t � ��}|dk rjt|��|dkr�t t
�fdd�t|���}t t
� fdd�t|���}tj�� tj� � ndS ||fS )z�PMAPI - Return names and status of children of the given metric NAME
(tuple names,tuple status) = pmGetChildrenStatus("kernel")
r zutf-8c s t � | j� �S )N)r< r= )r� )rY r% r& r� � s z/pmContext.pmGetChildrenStatus.<locals>.<lambda>c s t � | �S )N)r. )r� )� childstatr% r& r� � s N)NN)r r r r: rZ rP r( r- rT rM �pmGetChildrenStatusr r+ r� r> r\ r] )r0 r� rZ r^ ZstatLr% )r_ rY r& r` � s$
z pmContext.pmGetChildrenStatusc C s8 t j| j�}|dk r t|��t j� }|dk r4t|��|S )zUPMAPI - Return the namespace location type
loc = pmGetPMNSLocation()
r )r: rZ rP r( �pmGetPMNSLocation)r0 rZ r% r% r& ra � s zpmContext.pmGetPMNSLocationc C sN t j| j�}|dk r t|��t|t�s0|jd�}t j|�}|dk rJt|��|S )zTPMAPI - Load a local namespace
status = pmLoadNameSpace("filename")
r zutf-8)r: rZ rP r( r- rT rM �pmLoadNameSpace)r0 �filenamerZ r% r% r& rb � s
zpmContext.pmLoadNameSpacec
C s4 t j| j�}|dk r t|��t|ttf�r0d}nt|�}t| � }t|t�r`t|j d��|d< n\t|t�rxt|�|d< nDxBt
|�D ]6\}}t|| t�r�t|�||< q�t|j d��||< q�W t | � }t t| t
t �gt j_t j|||�}|dk r�t||��|dk�r0||k�r0dd� t||�D �} ttj| ��|S )z�PMAPI - Lookup pmIDs from a list of metric names nameA
c_uint pmid [] = pmLookupName("MetricName")
c_uint pmid [] = pmLookupName(("MetricName1", "MetricName2", ...))
r r6 zutf-8c S s g | ]\}}|t jkr|�qS r% )r2 Z
PM_ID_NULL)r� r� r� r% r% r& r� � s z*pmContext.pmLookupName.<locals>.<listcomp>)r: rZ rP r( r- r< rT r? r rM � enumerater r r � pmLookupNamer! �zipr2 Z PM_ERR_NAME)
r0 ZnameAZrelaxedrZ �n�namesr� r� �pmidAZbadLr% r% r& re � s0
zpmContext.pmLookupNamec sn t j| j�}|dk r t|��tt�� � t j|t� ��}|dk rFt|��tt � fdd�t
|���}t j � � |S )zvPMAPI - Return list of all metric names having this identical PMID
tuple names = pmNameAll(metric_id)
r c s t � | j� �S )N)r< r= )r� )�nameA_pr% r& r� � s z%pmContext.pmNameAll.<locals>.<lambda>)
r: rZ rP r( r r � pmNameAllr r+ r� r> r\ r] )r0 r� rZ �nameLr% )rj r& rk � s
zpmContext.pmNameAllc C s^ t � }tj| j�}|dk r"t|��tj|t|��}|dk rBt|��|j}tj |� t
|j � �S )zYPMAPI - Return a metric name from a PMID
name = pmNameID(self.metric_id)
r ) r r: rZ rP r( �pmNameIDr rD r\ r] r< r= )r0 r� r� rZ r@ r% r% r& rm � s
zpmContext.pmNameIDc C s< t j| j�}|dk r t|��tj||�}|dk r8t|��dS )z�PMAPI - Scan namespace, depth first, run CALLBACK at each node
status = pmTraversePMNS("kernel", traverse_callback)
r N)r: rZ rP r( r2 Z pmnsTraverse)r0 r� �callbackrZ r% r% r& �pmTraversePMNS s zpmContext.pmTraversePMNSc C s8 t j| j�}|dk r t|��t j� }|dk r4t|��dS )zmPMAPI - Unloads a local PMNS, if one was previously loaded
pm.pmUnLoadNameSpace("NameSpace")
r N)r: rZ rP r( �pmUnloadNameSpace)r0 rZ r% r% r& �pmUnLoadNameSpace s zpmContext.pmUnLoadNameSpacec C s� t |t�s|jd�}t |t�s(|jd�}t� }tj||t|��}|dkrlt|jj � �}t
j |� t t
j|��tj| j�}|dk r�t |��dS )z�PMAPI - Register a derived metric name and definition
pm.pmRegisterDerived("MetricName", "MetricName Expression")
zutf-8r N)r- rT rM r r: �pmRegisterDerivedMetricr r< rD r= r\ r] r( r2 � PM_ERR_CONV�pmReconnectContextrP )r0 r� �exprrY r@ r
rZ r% r% r& �pmRegisterDerived s
zpmContext.pmRegisterDerivedc C sN t |t�s|jd�}tj|�}|dk r.t|��tj| j�}|dk rJt|��dS )zuPMAPI - Register derived metric names and definitions from a file
pm.pmLoadDerivedConfig("FileName")
zutf-8r N)r- rT rM r: �pmLoadDerivedConfigr( rt rP )r0 ZfnamerZ r% r% r& rw ) s
z pmContext.pmLoadDerivedConfigc C s t j� } | dk r t| j� �S dS )z�PMAPI - Return an error message if the pmRegisterDerived(3) metric
definition cannot be parsed
pm.pmRegisterDerived()
N)r: �pmDerivedErrStrr< r= )r@ r% r% r& rx 8 s zpmContext.pmDerivedErrStrc C s` t j| j�}|dk r t|��tjtt��}t|t t��}t
|�}t j ||�}|dk r\t|��|S )zvPMAPI - Lookup a metric description structure from a pmID
pmDesc* pmdesc = pmLookupDesc(c_uint pmid)
r ) r: rZ rP r( r r8 r r� r r r � pmLookupDesc)r0 Zpmid_prZ Zdescbuf�descr� r% r% r& ry F s zpmContext.pmLookupDescc C s� t j| j�}|dk r t|��t|t�r:td � }||d< n0tt|� � }x t|�D ]\}}t|�||< qRW t j
t|�t t � �}t
|tt ��}t jt|�||�}|dk r�t|��tt �t|� � }x$tt|��D ]}t|| �||< q�W |S )z�PMAPI - Lookup metric description structures from pmIDs
(pmDesc* pmdesc)[] = pmLookupDescs(c_uint pmid[N])
(pmDesc* pmdesc)[] = pmLookupDescs(c_uint pmid)
r r6 )r: rZ rP r( r- �
integer_typesr r? rd r r8 r r� r r �
pmLookupDescsr> r ) r0 Zpmids_prZ �pmidsr� r� ZdescsbufZdesclist�descsr% r% r& r| X s$
zpmContext.pmLookupDescsc C sd t � }tj| j�}|dk r"t|��tjt|�|t|��}|dk rHt|��|j}t j
|� t |j � �S )z|PMAPI - Lookup the description of a metric's instance domain
"instance" = pmLookupInDomText(pmDesc pmdesc)
r )
r r: rZ rP r( �pmLookupInDomTextr� r rD r\ r] r< r= )r0 r� �kind�bufrZ r@ r% r% r& r w s
zpmContext.pmLookupInDomTextc C sX t � }tj| j�}|dk r"t|��tj||t|��}|dk rDt|��|j}tj |� |S )zePMAPI - Lookup the description of a metric from its pmID
"desc" = pmLookupText(pmid)
r )
r r: rZ rP r( � pmLookupTextr rD r\ r] )r0 r� r� r� rZ r
r% r% r& r� � s
zpmContext.pmLookupTextc s� |dkr |dkr t tjd��tt�� � tt�� �tj| j�}|dk rLt |��|dkr\t |�}tj
|t � �t ���}|dk r�t |��|dkr�t t
�fdd�t|���}t t
� fdd�t|���}tj� � tj�� nd}d}||fS )z�PMAPI - Lookup the list of instances from an instance domain PMDESCP or indom
([instance1, instance2...] [name1, name2...]) pmGetInDom(pmDesc pmdesc)
Nzinvalid argumentsr c s t � | jdd��S )N�ascii�ignore)r< r= )r� )rj r% r& r� � s z&pmContext.pmGetInDom.<locals>.<lambda>c s t � | �S )N)r. )r� )�instA_pr% r& r� � s )r( r2 ZPM_ERR_GENERICr r r r: rZ rP r� �
pmGetInDomr r+ r� r> r\ r] )r0 �pmdescpr� rZ rl �instLr% )r� rj r& r� � s(
zpmContext.pmGetInDomc C sx t j| j�}|dk r t|��i }| j|d�\}}|dks@|dkrD|S t|�}x&t|�D ]}|j|| || i� qVW |S )z1 helper to return dict of inst:name for an indom r )r� N)r: rZ rP r( r� r? r> �update)r0 r� rZ ZretDr� rl rg r� r% r% r& �pmGetInDomDict� s zpmContext.pmGetInDomDictc C sT t j| j�}|dk r t|��t|t�s0|jd�}t jt|�|�}|dk rPt|��|S )z�PMAPI - Lookup the instance id with the given NAME in the indom
c_uint instid = pmLookupInDom(pmDesc pmdesc, "Instance")
r zutf-8) r: rZ rP r( r- rT rM �
pmLookupInDomr� )r0 r� r� rZ r% r% r& r� � s
zpmContext.pmLookupInDomc C sv |t jkrdS t� }tj| j�}|dk r0t|��tjt|�|t |��}|dk rVt|��|j
}t j |� t
|jdd��S )z�PMAPI - Lookup the text name of an instance in an instance domain
"string" = pmNameInDom(pmDesc pmdesc, c_uint instid)
�
PM_IN_NULLr r� r� )r2 r� r r: rZ rP r( � pmNameInDomr� r rD r\ r] r< r= )r0 r� Zinstval�name_prZ r@ r% r% r& r� � s
zpmContext.pmNameInDomc C s dS )z�PMAPI - NOOP - Establish a new PMAPI context (done in constructor)
This is unimplemented. A new context is established when a pmContext
object is created.
Nr% )r0 r� r� r% r% r& rJ � s zpmContext.pmNewContextc C s dS )z�PMAPI - NOOP - Destroy a PMAPI context (done in destructor)
This is unimplemented. The context is destroyed when the pmContext
object is destroyed.
Nr% )r0 �handler% r% r& rL � s zpmContext.pmDestroyContextc C s8 t j| j�}|dk r t|��t j� }|dk r4t|��|S )zfPMAPI - Duplicate the current PMAPI Context
This supports copying a pmContext object
r )r: rZ rP r( � pmDupContext)r0 rZ r% r% r& r� � s zpmContext.pmDupContextc C s dS )z�PMAPI - NOOP - Set the PMAPI context to that identified by handle
This is unimplemented. Context changes are handled by the individual
methods in a pmContext class instance.
Nr% )r0 r� r% r% r& rZ s zpmContext.pmUseContextc C s t j� } | dk rt| ��| S )zcPMAPI - Returns the handle of the current PMAPI context
context = pmWhichContext()
r )r: �pmWhichContextr( )rZ r% r% r& r� s zpmContext.pmWhichContextc C s� t |t�r"d}t| � }||d< nN|dks0| r@d}tt�� }n0t|�}t| � }x t|�D ]\}}|||< q\W tj| j�}|dk r�t |��tj
t |�||�}|dk r�t |��|S )z�PMAPI - add instances to list that will be collected from indom
status = pmAddProfile(pmDesc pmdesc, c_uint instid)
r6 r N) r- r. r r r? rd r: rZ rP r( � pmAddProfiler� )r0 r� r� �numinst�instArA rD rZ r% r% r& r� s$
zpmContext.pmAddProfilec C s� |dks| r d}t t�� }n0t|�}t| � }x t|�D ]\}}|||< q:W tj| j�}|dk rjt|��tjt |�||�}|dk r�t|��|S )z�PMAPI - delete instances from list to be collected from indom
status = pmDelProfile(pmDesc pmdesc, c_uint inst)
status = pmDelProfile(pmDesc pmdesc, [c_uint inst])
Nr )
r r r? rd r: rZ rP r( � pmDelProfiler� )r0 r� r� r� r� rA rD rZ r% r% r& r� , s
zpmContext.pmDelProfilec C sR t j| j�}|dk r t|��d}|dk r0t|�}t j|||�}|dk rNt|��|S )z|PMAPI - set interpolation mode for reading archive files
code = pmSetMode(c_api.PM_MODE_INTERP, timeval, 0)
r N)r: rZ rP r( r � pmSetMode)r0 r> ZtimeValr? rZ Zwhenr% r% r& r� B s zpmContext.pmSetModec C s t j| j�}|dk r t|��|S )z�PMAPI - Reestablish the context connection
Unlike the underlying PMAPI function, this method takes no parameter.
This method simply attempts to reestablish the the context belonging
to its pmContext instance object.
r )r: rt rP r( )r0 rZ r% r% r& rt Q s z pmContext.pmReconnectContextc C s, t j}tj|�}tj| j||�}t|j� �S )z�PMAPI - Lookup the hostname for the given context
This method simply returns the hostname for the context belonging to
its pmContext instance object.
"hostname" = pmGetContextHostName()
) r2 r� r r8 r: �pmGetContextHostName_rrP r< r= )r0 Zbuflen�bufferr@ r% r% r& �pmGetContextHostName] s
z pmContext.pmGetContextHostNamec C s8 t j| j�}|dk r t|��t j� }|dk r4t|��|S )z5PMAPI - Query and set the current reporting timezone r )r: rZ rP r( �pmNewContextZone)r0 rZ r% r% r& r� m s zpmContext.pmNewContextZonec C s2 t | t�s| jd�} tj| �}|dk r.t|��|S )z:PMAPI - Create new zone handle and set reporting timezone zutf-8r )r- rT rM r: � pmNewZoner( )r� rZ r% r% r& r� w s
zpmContext.pmNewZonec C s t j| �}|dk rt|��|S )z,PMAPI - Sets the current reporting timezone r )r: � pmUseZoner( )Z tz_handlerZ r% r% r& r� � s
zpmContext.pmUseZonec C s6 t � } tjt| ��}|dk r$t|��| j}t|j� �S )z-PMAPI - Query the current reporting timezone r )r r: � pmWhichZoner r( rD r< r= )Ztz_prZ r� r% r% r& r� � s zpmContext.pmWhichZonec C sF t j| j�}|dk r t|��t� }tt|��}t jt|�t|�� |S )z;PMAPI - convert the date and time for a reporting timezone r ) r: rZ rP r( rm r rb � pmLocaltimer )r0 �secondsrZ r@ r r% r% r& r� � s zpmContext.pmLocaltimec C sP t j| j�}|dk r t|��tjd�}tt|��}t jt |�|� t
|j j � �S )z:PMAPI - format the date and time for a reporting timezone r r{ )
r: rZ rP r( r r8 r rb r| r r< rD r= )r0 r� rZ r@ r r% r% r& r| � s
zpmContext.pmCtimec C sP t t�� }tj| j�}|dk r&t|��tjt|�|t|��}|dk rLt|��|S )zkPMAPI - Fetch pmResult from the target source
pmResult* pmresult = pmFetch(c_uint pmid[])
r ) r r� r: rZ rP r( �pmFetchr? r )r0 ri �result_prZ r% r% r& r� � s
zpmContext.pmFetchc C s t j| � dS )zgPMAPI - Free a result previously allocated by pmFetch
pmFreeResult(pmResult* pmresult)
N)r: � pmFreeResult)r� r% r% r& r� � s zpmContext.pmFreeResultc C sH t |�gtj_tj| j�}|dk r*t|��tj|�}|dk rDt|��|S )zoPMAPI - Set values on target source, inverse of pmFetch
pmresult = pmStore(pmResult* pmresult)
r )r� r: �pmStorer! rZ rP r( )r0 r@ rZ r% r% r& r� � s
zpmContext.pmStorec C sD t � }tj| j�}|dk r"t|��tjt|��}|dk r@t|��|S )z]PMAPI - Get the label record from the archive
loglabel = pmGetArchiveLabel()
r )r� r: rZ rP r( �pmGetArchiveLabelr )r0 ZloglabelrZ r% r% r& r� � s zpmContext.pmGetArchiveLabelc C sD t � }tj| j�}|dk r"t|��tjt|��}|dk r@t|��|S )zAPMAPI - Get the last recorded timestamp from the archive
r )rP r: rZ rP r( �pmGetArchiveEndr )r0 rX rZ r% r% r& r� � s zpmContext.pmGetArchiveEndc s� t t�� � t t�� �tj| j�}|dk r0t|��t|�}tj|t � �t ���}|dk r^t|��|dkr�t
t �fdd�t |���}t
t � fdd�t |���}t
j� � t
j�� nd}d}||fS )z�PMAPI - Get the instance IDs and names for an instance domain
((instance1, instance2...) (name1, name2...)) pmGetInDom(pmDesc pmdesc)
r c s t � | jdd��S )Nr� r� )r< r= )r� )rj r% r& r� � s z-pmContext.pmGetInDomArchive.<locals>.<lambda>c s t � | �S )N)r. )r� )r� r% r& r� � s N)r r r r: rZ rP r( r� �pmGetInDomArchiver r+ r� r> r\ r] )r0 r� rZ r� rl r� r% )r� rj r& r� � s"
zpmContext.pmGetInDomArchivec C sT t j| j�}|dk r t|��t|t�s0|jd�}t jt|�|�}|dk rPt|��|S )z�PMAPI - Lookup the instance id with the given name in the indom
c_uint instid = pmLookupInDomArchive(pmDesc pmdesc, "Instance")
r zutf-8) r: rZ rP r( r- rT rM �pmLookupInDomArchiver� )r0 r� r� rZ r% r% r& r� s
z pmContext.pmLookupInDomArchivec C sl t � }tj| j�}|dk r"t|��t|�}tj||t|��}|dk rLt|��|j}t j
|� t |j dd��S )z�PMAPI - Lookup the text name of an instance in an instance domain
"string" = pmNameInDomArchive(pmDesc pmdesc, c_uint instid)
r r� r� )
r r: rZ rP r( r� �pmNameInDomArchiver rD r\ r] r< r= )r0 r� r� r� rZ r� r@ r% r% r& r� s
z pmContext.pmNameInDomArchivec C sH t t�� }tj| j�}|dk r&t|��tjt|��}|dk rDt|��|S )zbPMAPI - Fetch measurements from the target source
pmResult* pmresult = pmFetch()
r )r r� r: rZ rP r( �pmFetchArchiver )r0 r� rZ r% r% r& r� ! s
zpmContext.pmFetchArchive� c C s4 i }|dk r0|j dkr0|jdk r0tj|jj� �}|S )zk return a dict of a pmLabelSet, i.e. {name: value, ...}
flags arg is currently ignored
Nr )r� r� �loadsr= )r0 �lsetr� �retr% r% r& �pmlabelset_to_dict/ s z pmContext.pmlabelset_to_dictc C s� i }t j| j�}|dk r t|��| j|�}| j� }|rF|jtj|i� | j t j
|��}|rj|jtj |i� |j tj
kr�| j|j �}|r�|jtj|i� | j|�}|r�|jtj|i� | j|�}|r�|jtj|i� |S )z�PMAPI - Get all labels for a single metric, excluding instance
level labels (use pmGetInstancesLabels for those).
Return dict of {type: {name: value, ...}, ...}
r )r: rZ rP r( ry �pmGetContextLabelsr� r2 ZPM_LABEL_CONTEXT�pmGetDomainLabels� pmID_domainZPM_LABEL_DOMAINr� �
PM_INDOM_NULL�pmGetInDomLabelsZPM_LABEL_INDOM�pmGetClusterLabelsZPM_LABEL_CLUSTER�pmGetItemLabelsZ
PM_LABEL_ITEM)r0 r� r� rZ rz r� r% r% r& �pmLookupLabels: s,
zpmContext.pmLookupLabelsc C s� i }t j| j�}|dk r t|��|tjkr.|S tt�� }t j|t |��}|dk rXt|��x>t
|�D ]2}|| }|j dk rb|j |j
t j|j j� �i� qbW |dkr�t j||� |S )z�PMAPI - Get instance level labels for all instances in indom
return a dict {instid: {name: value, ...}, ...}
r N)r: rZ rP r( r2 r� r r� �pmGetInstancesLabelsr r> r� r� r� r� r= �pmFreeLabelSets)r0 r� Z instlabelsDrZ r� r� r� r% r% r& r� \ s"
z pmContext.pmGetInstancesLabelsc C sp t t�� }tj| j�}|dk r&t|��tj|t|��}|dk rFt|��|dkrRi S | j|d �}| j |d� |S )z�PMAPI - Get labels of a given metric identifier
On success, this returns a dict of the labels in a single pmLabelSet
r r6 )
r r� r: rZ rP r( r� r r� r� )r0 r� r� rZ r� r% r% r& r� s s
zpmContext.pmGetItemLabelsc C sp t t�� }tj| j�}|dk r&t|��tj|t|��}|dk rFt|��|dkrRi S | j|d �}| j |d� |S )z�PMAPI - Get labels of a given metric cluster
On success, this returns a dict of the labels in a single pmLabelSet
r r6 )
r r� r: rZ rP r( r� r r� r� )r0 r� r� rZ r� r% r% r& r� � s
z pmContext.pmGetClusterLabelsc C s~ i }t t�� }tj| j�}|dk r*t|��|tjkr8|S tj|t |��}|dk rXt|��|dkrz| j
|d �}| j |d� |S )z�PMAPI - Get labels of a given instance domain
On success, this returns a dict of the labels in a single pmLabelSet
r r6 ) r r� r: rZ rP r( r2 r� r� r r� r� )r0 r� Z indomLabelsDr� rZ r% r% r& r� � s
zpmContext.pmGetInDomLabelsc C sp t t�� }tj| j�}|dk r&t|��tj|t|��}|dk rFt|��|dkrRi S | j|d �}| j |d� |S )z�PMAPI - Get labels of a given performance domain
On success, this returns a dict of the labels in a single pmLabelSet
r r6 )
r r� r: rZ rP r( r� r r� r� )r0 Zdomainr� rZ r� r% r% r& r� � s
zpmContext.pmGetDomainLabelsc C sn t t�� }tj| j�}|dk r&t|��tjt|��}|dk rDt|��|dkrPi S | j|d �}| j |d� |S )z�PMAPI - Get labels of the current context
On success, this returns a dict of the labels in a single pmLabelSet
r r6 )
r r� r: rZ rP r( r� r r� r� )r0 r� rZ r� r% r% r& r� � s
z pmContext.pmGetContextLabelsc C s� t | t�s| g}n| }tjtj�}tt|� � }x&t|�D ]\}}t|j d��||< q:W t
j |t|�|t|��}|dk r�t |��|j
}t|jdd��S )z3PMAPI - Merges string labels into a string
zutf-8r r� r� )r- r+ r r8 r2 �PM_MAXLABELJSONLENr r? rd rM r: �
pmMergeLabelsr( rD r< r= )r� ZlabelsLr� �arg_arrr� ZlabelrZ r@ r% r% r& r� � s
zpmContext.pmMergeLabelsc C s t jtj�}|dkr dd� }t|�}| dkr4d|_n�t| t�sF| g}n:g }x4| D ],}t|t�rj|j|� qP|dk rP|j |� qPW t
t �t |� � }x*t
|�D ] \}} tt| �t
t ��||< q�W tt|�t�}tj|t |�|t |�||�}
|
dk r�t|
��|j} t| jdd��S )z�PMAPI - Merges list of pmLabelSets based on labelSets hierarchy into
a string. Each list element may also be either a list or None.
Nc S s dS )Nr6 r% )r� �y�zr% r% r& r� � s z,pmContext.pmMergeLabelSets.<locals>.<lambda>s {}r r� r� )r r8 r2 r� �mergeLabelSetsCB_typerD r- r+ �extend�appendr r� r? rd r r r r r: �pmMergeLabelSetsr( r< r= ) � labelSetsrn �argr� Zcb_funcZ
labelSetsLr� r� r� ZlabelsetrZ r@ r% r% r& r� � s0
zpmContext.pmMergeLabelSetsr6 c C s< x6t |�D ]*}tt| | �tt��}|r
tj|d� q
W dS )z{PMAPI - Free the pmLabelSets memory. The labelsets argument is
an array of nsets pmLabelSet structures.
r6 N)r> r r r r� r: r� )r� Znsetsr� r� r% r% r& r� s zpmContext.pmFreeLabelSetsc C s6 t | t�s| jd�} tj| �}|dkr*|S t|j� �S )z@PMAPI - Return single value from environment or pcp config file zutf-8N)r- rT rM r: �pmGetOptionalConfigr< r= )Zvariabler@ r% r% r& � pmGetConfig s
zpmContext.pmGetConfigc C s( t jtj�}tj| |tj�}t|j� �S )z4PMAPI - Convert an error code to a readable string )r r8 r2 r9 r: r; r< r= )r/ Zerrstrr@ r% r% r& �pmErrStr s zpmContext.pmErrStrc C s0 t � }tj| ||t|�|�}|dk r,t|��|S )aO PMAPI - Extract a value from a pmValue struct and convert its type
pmAtomValue = pmExtractValue(results.contents.get_valfmt(i),
results.contents.get_vlist(i, 0),
descs[i].contents.type,
c_api.PM_TYPE_FLOAT)
r )r� r: �pmExtractValuer r( )r� r� ZintypeZouttype�outAtomrZ r% r% r& r� s
zpmContext.pmExtractValuec C sf t |t�r t� }d|_||_n|}t� }tj| t|�t|| j j
�t|�t|��}|dk rbt |��|S )z�PMAPI - Convert a value to a different scale
pmAtomValue = pmConvScale(c_api.PM_TYPE_FLOAT, pmAtomValue,
pmDesc*, 3, c_api.PM_SPACE_MBYTE)
r6 r ) r- r. r� r� r� r� r: � pmConvScaler r� r� r( )ZinTypeZinAtomrz Z
metric_idxZoutUnitsZpmunitsr� rZ r% r% r& r� / s
zpmContext.pmConvScalec C s$ t jd�}tj| |d�}t|j� �S )z2PMAPI - Convert units struct to a readable string r� )r r8 r: r� r< r= )r� r� r@ r% r% r& �
pmUnitsStrD s
zpmContext.pmUnitsStrc C s$ t jd�}tj| |d�}t|j� �S )z3PMAPI - Convert double value to fixed-width string rO )r r8 r: �
pmNumberStr_rr< r= )rD Znumstrr@ r% r% r& � pmNumberStrK s
zpmContext.pmNumberStrc C s t j| ||�}|S )z/PMAPI - build a pmID from domain, cluster, item)r: �
pmID_build)r� r r� r@ r% r% r& r� R s zpmContext.pmID_buildc C s t j| �}|S )z&PMAPI - return domain number from pmID)r: r� )r� r@ r% r% r& r� X s
zpmContext.pmID_domainc C s t j| �}|S )z'PMAPI - return cluster number from pmID)r: � pmID_cluster)r� r@ r% r% r& r� ^ s
zpmContext.pmID_clusterc C s t j| �}|S )z$PMAPI - return item number from pmID)r: � pmID_item)r� r@ r% r% r& r� d s
zpmContext.pmID_itemc C s$ t jd�}tj| |d�}t|j� �S )z,PMAPI - Convert a pmID to a readable string r{ )r r8 r: � pmIDStr_rr< r= )r� Zpmidstrr@ r% r% r& �pmIDStrj s
zpmContext.pmIDStrc C s t j| |�}|S )z-PMAPI - build an indom from domain and serial)r: �
pmInDom_build)r� �sr@ r% r% r& r� q s zpmContext.pmInDom_buildc C s t j| �}|S )z'PMAPI - return domain number from indom)r: �pmInDom_domain)r� r@ r% r% r& r� w s
zpmContext.pmInDom_domainc C s t j| �}|S )z'PMAPI - return serial number from indom)r: �pmInDom_serial)r� r@ r% r% r& r� } s
zpmContext.pmInDom_serialc C s( t jd�}tjt| �|d�}t|j� �S )zpPMAPI - Convert an instance domain ID to a readable string
"indom" = pmGetInDom(pmDesc pmdesc)
r{ )r r8 r: � pmInDomStr_rr� r< r= )r� Zindomstrr@ r% r% r& �
pmInDomStr� s
zpmContext.pmInDomStrc C s$ t jd�}tj| |d�}t|j� �S )zwPMAPI - Convert a performance metric type to a readable string
"type" = pmTypeStr(c_api.PM_TYPE_FLOAT)
r{ )r r8 r: � pmTypeStr_rr< r= )r� Ztypestrr@ r% r% r& � pmTypeStr� s
zpmContext.pmTypeStrc C s* t jd�}tjt| �||d�}t|j� �S )zoPMAPI - Convert a value atom to a readable string
"value" = pmAtomStr(atom, c_api.PM_TYPE_U32)
�` )r r8 r: � pmAtomStr_rr r< r= )Zatomr� Zatomstrr@ r% r% r& � pmAtomStr� s
zpmContext.pmAtomStrc C s$ t jd�}tj| |d�}t|j� �S )z}PMAPI - Convert a performance metric semantic to a readable string
"string" = pmSemStr(c_api.PM_SEM_COUNTER)
r{ )r r8 r: �
pmSemStr_rr< r= )r� Zsemstrr@ r% r% r& �pmSemStr� s
zpmContext.pmSemStrc C sF t jt| �t|jj| jj�t|jj�t|jj| jj | �|� dS )zzPMAPI - Print the value of a metric
pmPrintValue(file, value, pmdesc, vset_index, vlist_index, min_width)
N)
r: � pmPrintValuer' r r� r� r� r� r r� )r$ r@ Zptyper� r� Z min_widthr% r% r& r� � s
zpmContext.pmPrintValuec C s t j� } | dk rt| ��| S )z7PMAPI - flush the internal buffer shared with pmprintf r )r: �pmflushr( )rZ r% r% r& r� � s zpmContext.pmflushc G s$ t j| f|�� }|dk r t|��dS )z=PMAPI - append message to internal buffer for later printing r N)r: rL r( )Zfmtr, rZ r% r% r& rL � s zpmContext.pmprintfc C s t j| � dS )z@PMAPI - sort all metric instances in result returned by pmFetch N)r: �pmSortInstances)r� r% r% r& r� � s zpmContext.pmSortInstancesc C s t j| �dfS )z�PMAPI - parse a textual time interval into a timeval struct
(timeval_ctype, '') = pmParseInterval("time string")
r� )rP r[ )rW r% r% r& rU � s zpmContext.pmParseIntervalr� c C s t j| ||�dfS )z�PMAPI - parse a textual metric specification into a struct
(result, '') = pmParseMetricSpec("hinv.ncpu", 0, "localhost")
r� )r� r� )r� r� r� r% r% r& r� � s zpmContext.pmParseMetricSpecc C s� t | ttf�s ttjt| ���t | t�s2| jd�} t� }t � }t
� }t j | t
|�t
|�t
|��}|dk r�t|jj� �}tj|� t||��||jfS )Nzutf-8r )r- rT � text_typer( r2 rs r< rM r� r r r: �pmParseUnitsStrr rD r= r\ r] )r� r@ rY Z
multiplierrZ r
r% r% r& r� � s
zpmContext.pmParseUnitsStrc C s | j � S )z� Delay for a specified amount of time (timeval).
Useful for implementing tools that do metric sampling.
Single arg is timeval in tuple returned from pmParseInterval().
)rf )rX r% r% r& �pmtimevalSleep� s zpmContext.pmtimevalSleepc C s t tjtd�jj� �S )NrB )r< r rC r: rD r= r% r% r% r& rB � s zpmContext.pmPrognamec C s t jtd�j| @ rdS dS )N�pmDebugTF)r rC r: rD )r� r% r% r& r� � s zpmContext.pmDebugc C s� |dkr|rdnd}n | r,t j| j� �j}n
t j� j}|r@t jnt j}t j| }|r�t|d �}t|d d �}|dkr�|d7 }|t|�7 }|r�|dt|� 7 }|S )z; Get current timezone offset string using POSIX convention r r6 g �@i �< �+r� ) re Z localtimer* rv Zaltzone�timezoneZtznamer. r< )rQ Zset_dst�dst�offsetr� Z offset_hrZ
offset_minr% r% r& �get_current_tz� s
zpmContext.get_current_tzc sd � s d� fdd�d D �kr dS d� kr6� j d�d n � j d�d }d� krPdnd}d| t|� S )
zC Convert POSIX timezone offset string to human readable UTC offset Tc s g | ] }|� k�qS r% r% )r� r )r� r% r& r�
s z4pmContext.posix_tz_to_utc_offset.<locals>.<listcomp>r� �-zUTC+0r6 ZUTC)r� r� )rW r< )r� r� Zsignr% )r� r& �posix_tz_to_utc_offset
s
$z pmContext.posix_tz_to_utc_offsetc C sx | j � r.| j � tjd< tj� tj| j � � nF| j� rNtj� tjd< tj� n&tj | �}|tjd< tj� tj|� dS )z Set timezone for a Python tool ZTZN)
r. r" �environre ZtzsetrB r� r- r� r� )rQ r� r% r% r& � set_timezone
s
zpmContext.set_timezonec C s� | t j jd� }|tjkr>|j|j|jd d d d
}n�|tjkrl|j|j|jd d d d }nd|tjkr�|j|j|jd d d
d }n6|tj kr�|j|j|jd d d d }nt
d��|S )z6 Convert datetime value to seconds of given precision r g 8@g �@g $@ry � g �?z Unsupported precision requestedg ��.Ag ��.Ag ��.Ag @�@g ��.Ag ��.Ag @�@) �datetimeZ
fromtimestampr2 � PM_TIME_SECZ microsecondsr� Zdays� PM_TIME_MSECZ PM_TIME_USECZ PM_TIME_NSEC�
ValueError)rD Z precisionZtdtZtstr% r% r& �datetime_to_secs'
s
$
$
$
$zpmContext.datetime_to_secsc C sr | s
| rt j}d}nPt j}d}|j|krB|j}|t jt j�O }n$|jd |jd }|t jt j�O }|t|�fS )z! Get mode and step for pmSetMode r i � i� ) r2 Z PM_MODE_FORWr� rQ Z
PM_XTB_SETr� rR r� r. )r2 �interpolrW r> �stepZsecs_in_24_daysr% r% r& �
get_mode_step7
s
zpmContext.get_mode_stepc C sZ t j| j�}|dk r t|��| j|� | jtjkrVtj |||�\}}| j
||j � |� dS )z Common execution preparation r N) r: rZ rP r( r� r� r2 rM rB r� r� r* )r0 rQ r2 r� rW rZ r> r� r% r% r& �prepare_executeH
s
zpmContext.prepare_execute)r r )r )NN)r� )NN)r6 )r r� ���)Nr� )orG rH rI r� rD rF rH r� r� rK rP r2 rN r* r� rj rR rA rX r[ r` ra rb re rk rm ro rq rv rw rx ry r| ZPM_TEXT_ONELINEr r� r� r� r� r� rJ rL r� rZ r� r� r� r� rt 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� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rL r� rU r� r� r� rB r� r� r� r� r� r� r� r� r% r% r% r& rB � s� / /
#
" #
rB c @ s� e Zd ZdZG dd� de�ZG dd� de�ZG dd� de�ZG dd � d e�ZG d
d � d e �Z
e j d fd
d�Z
dd� Zdd� Zd!dd�Zd"dd�Zdd� Zd#dd �Zd d � Zd d � ZdS )$�
fetchgroupa� Defines a PMAPI fetchgroup.
This class wraps the pmFetchGroup set of C PMAPI functions (q.v.)
in an object-oriented manner.
Each instance of this class represents one fetchgroup, in which
interest in several metrics (individual or indoms) is registered.
Each registration results in an function-like object that may be
called to decode that metric's value(s). Errors are signalled
with exceptions rather than result integers. Strings are all
UTF-8 encoded.
c @ s e Zd ZdZdd� Zdd� ZdS )zfetchgroup.fetchgroup_itemz�
An internal class to receive value/status for a single item.
It may be called as if it were a function object to decode
the embedded pmAtomValue, which was set at the most recent
.fetch() call.
c C s t tj�| _|| _t� | _dS )z8Allocate a single instance to receive a fetchgroup item.N)r r2 Z PM_ERR_VALUE�sts�pmtyper� rD )r0 r� r% r% r& r* �
s z#fetchgroup.fetchgroup_item.__init__c C s& | j jdk rt| j j��| jj| j�S )z>Retrieve a converted value of a fetchgroup item, if available.r )r� rD r( r� r� )r0 r% r% r& �__call__�
s z#fetchgroup.fetchgroup_item.__call__N)rG rH rI r� r* r� r% r% r% r& �fetchgroup_item�
s r� c @ s e Zd ZdZdd� Zdd� ZdS )z fetchgroup.fetchgroup_timestampz�
An internal class to receive value for a single timestamp.
It may be called as if it were a function object to decode
the timestamp, which was set at the most recent
.fetch() call, into a datetime object.
c C s t � | _|| _dS )z=Allocate a single instance to receive a fetchgroup timestamp.N)rP rD rP )r0 rP r% r% r& r* �
s z(fetchgroup.fetchgroup_timestamp.__init__c C sL | j j| jj�}t| jj�}tj|jd |jd |j |j
|j |j |d�}|S )z�
Retrieve a converted value of a timestamp, if available. Use
pmLocaltime() to convert to a datetime object.
il r6 N)
rP r� rD rQ r. rR r� rs rr rq rp ro rn )r0 �ts�us�dtr% r% r& r� �
s
z(fetchgroup.fetchgroup_timestamp.__call__N)rG rH rI r� r* r� r% r% r% r& �fetchgroup_timestamp�
s r c @ s e Zd ZdZdd� Zdd� ZdS )zfetchgroup.fetchgroup_indomaq
An internal class to receive value/status for an indom of
items. It may be called as if it were a function object to
create an list of tuples containing instance-code/-name/value
information. Each value is a function object that decodes
the embedded pmAtomValue, which was set at the most recent
fetch() call.
c C sZ t | }t| }t| }t| }t � | _|� | _|| _|� | _|� | _|� | _ t� | _
dS )z8Allocate a single instance to receive a fetchgroup item.N) r r� r r r� �stssr� �values�icodes�inames�num)r0 r� r �stss_t�values_tZicodes_tZinames_tr% r% r& r* �
s z$fetchgroup.fetchgroup_indom.__init__c s| g }�j jdk r t�j j��xZt�jj�D ]J}dd� � |j�j| �j| r\�j| jd�nd� �fdd�|�f� q*W |S )z>Retrieve a converted value of a fetchgroup item, if available.r c S s. | j | dk r t| j | ��| j| j| j�S )Nr )r r( r r� r� )r0 r� r% r% r& �
decode_one�
s z8fetchgroup.fetchgroup_indom.__call__.<locals>.decode_onezutf-8Nc s �� �fdd�S )Nc s
� ���S )Nr% r% )r r� r0 r% r& r� �
s zHfetchgroup.fetchgroup_indom.__call__.<locals>.<lambda>.<locals>.<lambda>r% )r� )r r0 )r� r& r� �
s z6fetchgroup.fetchgroup_indom.__call__.<locals>.<lambda>) r� rD r( r> r r� r r r= )r0 �vvr� r% )r r0 r& r� �
s z$fetchgroup.fetchgroup_indom.__call__N)rG rH rI r� r* r� r% r% r% r& �fetchgroup_indom�
s r
c @ s e Zd ZdZdd� Zdd� ZdS )zfetchgroup.fetchgroup_eventak
An internal class to receive value/status for an
event record field. It may be called as if it were a function
object to create an list of tuples containing timestamp/value
information. Each value is a function object that decodes
the embedded pmAtomValue, which was set at the most recent
fetch() call.
c C sP t | }t| }t| }t � | _|� | _|| _|� | _|� | _t� | _ || _
dS )z8Allocate a single instance to receive a fetchgroup item.N) r r� rk r� r r� �timesr r r rP )r0 r� r rP r r
Z
timespec_tr% r% r& r* �
s z$fetchgroup.fetchgroup_event.__init__c
s� g }�j jdk r t�j j��x�t�jj�D ]|}dd� � �jj�j| j�}t �j| j
�d }t j |j d |j
d |j|j|j|j|d�}|j|� �fdd �|�f� q*W |S )
z>Retrieve a converted value of a fetchgroup item, if available.r c S s. | j | dk r t| j | ��| j| j| j�S )Nr )r r( r r� r� )r0 r� r% r% r& r �
s z8fetchgroup.fetchgroup_event.__call__.<locals>.decode_onei� il r6 Nc s �� �fdd�S )Nc s
� ���S )Nr% r% )r r� r0 r% r& r� s zHfetchgroup.fetchgroup_event.__call__.<locals>.<lambda>.<locals>.<lambda>r% )r� )r r0 )r� r& r� s z6fetchgroup.fetchgroup_event.__call__.<locals>.<lambda>)r� rD r( r> r rP r� r rQ r. rl r� rs rr rq rp ro rn r� )r0 r r� r r r r% )r r0 r& r� �
s z$fetchgroup.fetchgroup_event.__call__N)rG rH rI r� r* r� r% r% r% r& �fetchgroup_event�
s
r c @ s e Zd ZdZdd� Zdd� ZdS )z fetchgroup.pmContext_borrowedz�
An internal class for accessing the private PMAPI context
belonging to a fetchgroup. It works just like a pmContext,
except it overrides the constructor/destructor to reflect
the "borrowed" state of the context.
c C s || _ || _|| _dS )z/Override pmContext ctor to eschew pmNewContext.N)rG rC rE )r0 rP r� rK r% r% r& r* s z&fetchgroup.pmContext_borrowed.__init__c C s t dk r | jt jkr t j| _dS )z3Override pmContext ctor to eschew pmDestroyContext.N)r2 rG rI )r0 r% r% r& r� s z%fetchgroup.pmContext_borrowed.__del__N)rG rH rI r� r* r� r% r% r% r& �pmContext_borrowed s r zlocal:c C sj t � | _g | _|tjkr$|dkr$d}tjt| j�||jd��}|dk rNt |��t
j tj | j�||�| _
dS )z%Create a fetchgroup from a pmContext.Nr� zutf-8r )r �pmfg�itemsr2 rO r: �pmCreateFetchGroupr rM r( r� r �pmGetFetchGroupContextrP )r0 r� rK r� r% r% r& r* s zfetchgroup.__init__c C s@ t dk r0| jjdk r0t j| j�}|dk r0t|��| jdd�= dS )z?Destroy the fetchgroup. Drop references to fetchgroup_* items.Nr )r: r rD �pmDestroyFetchGroupr( r )r0 r� r% r% r& r� , s
zfetchgroup.__del__c C s | j S )z�
Return the private pmContext used by the fetchgroup.
WARNING: mutation of this context by other PMAPI functions
may disrupt fetchgroup functionality.
)rP )r0 r% r% r& � get_context4 s zfetchgroup.get_contextNc C s� |dkrt tj ��|dkr>| jj|�}| jj|�}|d j}tj|�}t j
| j t |r`|j
d�nd�t |rt|j
d�nd�t |r�|j
d�nd�t|j�t|�t|j��}|dk r�t |��| jj|� |S )z�Extend the fetchgroup with a single metric. Infer type if
necessary. Convert scale/rate if appropriate/requested.
Requires a specified instance if metric has an instance
domain.
Nr zutf-8)r( rF �EINVALrP re r| r� r� r� r: �pmExtendFetchGroup_itemr r rM r rD r r� r r� ) r0 r� �mtype�scale�instancer} r~ �vr� r% r% r& � extend_item< s"
zfetchgroup.extend_item�d c
C s
|dks|dk r t tj ��|dkrF| jj|�}| jj|�}|d j}tj||�}t j
| j t |rj|j
d�nd�t |r~|j
d�nd�tt|j�tt��tt|j�tt ��tt|j�tt��t|�tt|j�tt��t|�t|j�t|j�� }|dk r�t |��| jj|� |S )z�Extend the fetchgroup with up to @maxnum instances of a metric.
(Metrics without instances are also accepted.) Infer type if
necessary. Convert scale/rate if appropriate/requested.
Nr zutf-8) r( rF r rP re r| r� r� r
r: �pmExtendFetchGroup_indomr r rM r r r r r r r r� r r r r� r r� ) r0 r� r r �maxnumr} r~ r r� r% r% r& � extend_indomW s(
zfetchgroup.extend_indomc C s@ t j| j�}tj| jt|j��}|dk r0t|��| j j
|� |S )z.Extend the fetchgroup with a timestamp query. r ) r� r rP r: � pmExtendFetchGroup_timestampr r rD r( r r� )r0 r r� r% r% r& �extend_timestamps s zfetchgroup.extend_timestampc C s& |dks|dk r t tj ��|dkrF| jj|�}| jj|�}|d j}tj||| j�} t j
| j t |rn|j
d�nd�t |r�|j
d�nd�t |r�|j
d�nd�t |r�|j
d�nd�tt| j�tt��tt| j�tt��t|�tt| j�tt��t|�t| j�t| j�� }
|
dk �rt |
��| jj| � | S )z�Extend the fetchgroup with up to @maxnum instances of the given
field of the given event metric's records. Infer type if necessary.
Convert scale if appropriate/requested.
Nr zutf-8) r( rF r rP re r| r� r� r r: �pmExtendFetchGroup_eventr r rM r r r r rk r r� r r r r r� r r� ) r0 r� ZfieldZftyper r r r} r~ r r� r% r% r& � extend_event} s*
zfetchgroup.extend_eventc C s t j| j�}|dk r t|��|S )z?Fetch all the metrics in this fetchgroup and update all values.r )r: � pmFetchGroupr r( )r0 r� r% r% r& �fetch� s zfetchgroup.fetchc C s2 t j| j�}| jdd�= |dk r(t|��g | _dS )z>Clear all the metrics in this fetchgroup ready to start again.Nr )r: �pmClearFetchGroupr r r( )r0 r� r% r% r& �clear� s
zfetchgroup.clear)NNNN)NNNr )NNNNNr )rG rH rI r� �objectr� r r
r rB r r2 rN r* r� r r r! r# r% r' r) r% r% r% r& r� z
s )-
r� )�r� r" r re rF r� r� Zcpmapir2 r r r r r r r r r r
r r r
r r r r r r r r r r Z ctypes.utilr r: �platformZ libc_namer\ r r. r{ rb r< r� Zunicoder' r� r( rK ZPM_SIZEOF_SUSECONDS_Trh rs ZPM_SIZEOF_TIME_Trg rP rk rm r� r� r� r� r� r� r� r� r� r� r� r� r� ZpmIDZpmInDomr� Z pmDescPtrr� r� r� r� r� r� r� r� Z
pmLabelPtrr� r� r� rD r� r� r[ r r! r` ra rb re rk rm ZtraverseCB_typero rp rr rw ry r| r r� r� r� r� rJ rL r� rZ r� r� r� r� rt 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� r� r� r� r� r� rU r� r� rL r� r� r� r� r� r� r� r� r� r� r� r� r* r� rB r r r( r r r r$ r" r& r� r% r% r% r& �<module>Y s6 ! + )&* 0
F