File: //opt/osm/venv/lib64/python3.10/site-packages/psutil/__pycache__/_psaix.cpython-310.pyc
o
=iG � @ s� d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m
Z
ddl m Z ddl m Z
ddl
mZ dd l
mZ dd
l
mZ dd l
mZ dd l
mZ dd
l
mZ ddl
mZ ddl
mZ ddl
mZ ddl
mZ dgZee
d�Zee
d�Zee
d�Z e
� � Z e
j Z e
j e
j!e
j"e
j#e
j$e
j%e
j&e
j%e
j'e
j(iZ)e
j*e
j+e
j,e
j-e
j.e
j/e
j0e
j1e
j2e
j3e
j4e
j5e
j6e
j7e
j8e
j9e
j:e
j;e
j<e
j=e
j>e
j?e
j@e
jAi ZBeCddddddddd �ZDed d d g�ZEeEZFed g d!��ZGed"g d#��ZHd$d%� ZId&d'� ZJd(d)� ZKd*d+� ZLd,d-� ZMd.d/� ZNd0d1� ZOe
jPZPe jQZQdFd3d4�ZRe
jSZSe�r"e
jTZTdGd6d7�ZUd8d9� ZVd:d;� ZWd<d=� ZXd>d?� ZYd@dA� ZZdBdC� Z[G dDdE� dE�Z\dS )Hz AIX platform implementation.� N)�
namedtuple� )�_common)�_psposix)� _psutil_aix)�NIC_DUPLEX_FULL)�NIC_DUPLEX_HALF)�NIC_DUPLEX_UNKNOWN)� AccessDenied)�
NoSuchProcess)�
ZombieProcess)�conn_to_ntuple)�get_procfs_path)�memoize_when_activated)�
usage_percentZ PROCFS_PATH� proc_threads�net_io_counters�proc_io_counters� � � � � � )�ppid�rss�vms� create_time�nice� num_threads�status�ttynr�pmemr r � scputimes)�user�systemZidleZiowait�svmem)�total� available�percent�used�freec C s4 t �� \} }}}}t| | | dd�}t| ||||�S )Nr �Zround_)�cextZ virtual_memr r& )r' Zavailr+ Z_pinnedZinuser) � r. �;/opt/osm/venv/lib/python3.10/site-packages/psutil/_psaix.py�virtual_memorye s r0 c C s: t �� \} }}}| | }t|| dd�}t�| |||||�S )z=Swap system memory as a (total, used, free, sin, sout) tuple.r r, )r- Zswap_memr r Zsswap)r' r+ �sinZsoutr* r) r. r. r/ � swap_memoryk s r2 c C s t �� } tdd� t| � D �� S )z.Return system-wide CPU times as a named tuple.c S s g | ]}t |��qS r. )�sum��.0�xr. r. r/ �
<listcomp>{ � z cpu_times.<locals>.<listcomp>)r- �
per_cpu_timesr# �zip��retr. r. r/ � cpu_timesx s r= c C s t �� } dd� | D �S )z6Return system per-CPU times as a list of named tuples.c S s g | ]}t |� �qS r. )r# r4 r. r. r/ r7 � r8 z!per_cpu_times.<locals>.<listcomp>)r- r9 r; r. r. r/ r9 ~ s r9 c C s" zt �d�W S ty Y dS w )z0Return the number of logical CPUs in the system.�SC_NPROCESSORS_ONLNN)�os�sysconf�
ValueErrorr. r. r. r/ �cpu_count_logical� s
�rB c C sv g d�} t j| t jt jd�}|�� \}}dd� ||fD �\}}|jdkr/| �d|� �}t|��|�� �� }t|�p:d S )N)Zlsdevz-Cc� processor��stdout�stderrc s � � | ]
}|� tjj�V qd S �N��decode�sysrE �encodingr4 r. r. r/ � <genexpr>� s � z"cpu_count_cores.<locals>.<genexpr>r z command error
) �
subprocess�Popen�PIPE� communicate�
returncode� RuntimeError�strip�
splitlines�len)�cmd�prE rF �msgZ
processorsr. r. r/ �cpu_count_cores� s
rZ c C s t �� \} }}}t�| |||�S )z*Return various CPU stats as a named tuple.)r- � cpu_statsr Z scpustats)Z ctx_switchesZ
interruptsZsoft_interruptsZsyscallsr. r. r/ r[ � s �r[ Fc C s\ g }t �� }|D ]#}|\}}}}|dkrd}| s t|�js qt�||||�}|�|� q|S )z Return system disk partitions.�none� )r- �disk_partitions�
disk_usager' r Z sdiskpart�append) �all�retlistZ
partitions� partitionZdeviceZ
mountpointZfstype�opts�ntupler. r. r/ r^ � s
r^ ���c C s~ t j| \}}t�|�}g }|D ],}|\}}} }
} } }
||vr q| |vr%qt||| |
| | t|dkr3|
ndd�}|�|� q|S )z�Return socket connections. If pid == -1 return system-wide
connections (as opposed to connections opened by one process only).
rf N��pid)r Z conn_tmapr- �net_connectionsr
� TCP_STATUSESr` )�kind�_pidZfamilies�types�rawlistr< �item�fdZfam�type_�laddr�raddrr rh �ntr. r. r/ ri � s*
�
ri c C s� t td�} dd� t� D �}i }|D ]c}t�|�}t�|�}d}d}tjdd|gtjtjd�}|� � \} }
d d
� | |
fD �\} }
|j
dkrZt � d | �} | d urZt
| �d
��}| �d�}d�|�} d|v }
| �|t�}t�|
|||| �||< q|S )z)Get NIC stats (isup, duplex, speed, mtu).)�FullZHalfc S s h | ]}|d �qS )r r. r4 r. r. r/ � <setcomp>� r8 z net_if_stats.<locals>.<setcomp>r] r z/usr/bin/entstatz-drD c s rG rH rI r4 r. r. r/ rM � � �
�z net_if_stats.<locals>.<genexpr>z"Running: (\d+) Mbps.*?(\w+) DuplexNr r �,�running)r r � net_if_addrsr- Z
net_if_mtuZ net_if_flagsrN rO rP rQ rR �re�search�int�group�join�getr r Z snicstats)Z
duplex_map�namesr< �nameZmtu�flagsZduplex�speedrX rE rF Z re_resultZ output_flagsZisupr. r. r/ � net_if_stats� s:
�
�
�
r� c C s t �� S )z:The system boot time expressed in seconds since the epoch.)r- � boot_timer. r. r. r/ r� s r� c C s\ g } t �� }d}|D ]!}|\}}}}}} |sq
||v r d}t�||||| �}
| �|
� q
| S )z:Return currently connected users as a list of namedtuples.)z:0.0z:0� localhost)r- �usersr Zsuserr` ) rb rn r� ro r$ �tty�hostnameZtstampZ user_processrh rt r. r. r/ r� s r� c C s dd� t �t� �D �S )z7Returns a list of PIDs currently running on the system.c S s g | ]
}|� � rt|��qS r. )�isdigitr} r4 r. r. r/ r7 / s zpids.<locals>.<listcomp>)r? �listdirr r. r. r. r/ �pids- s r� c C s t j�t j�t� t| �d��S )z&Check for the existence of a unix pid.Zpsinfo)r? �path�existsr r �strrg r. r. r/ �
pid_exists2 s r� c s t �� �� fdd��}|S )z�Call callable into a try/except clause and translate ENOENT,
EACCES and EPERM in NoSuchProcess or AccessDenied exceptions.
c
s� | j | j| j}}}z � | g|�R i |��W S ttfy6 } zt|�s+t||�|�t|||�|�d }~w tyG } zt ||�|�d }~ww rH )
rh �_ppid�_name�FileNotFoundError�ProcessLookupErrorr� r r �PermissionErrorr
)�self�args�kwargsrh r r� �err��funr. r/ �wrapper< s � ��z wrap_exceptions.<locals>.wrapper)� functools�wraps)r� r� r. r� r/ �wrap_exceptions7 s r� c @ st e Zd ZdZg d�Zdd� Zdd� Zdd� Zee d d
� ��Z
ee d d � ��Z ed
d� �Z edd� �Z
edd� �Zedd� �Zedd� �Zedd� �ZerRedd� �Zed=d d ��Zed d � �Zed d!� �Zed"d#� �Zed$d%� �Zed&d'� �Zed(d)� �Zed*d+� �Zed,d-� �Z ed.d/� �Z e Z ed0d1� �Z d2d3� Z ed4d5� �Z!ed6d7� �Z"ed>d9d:��Z#e$r�ed;d<� �Z%d8S d8S )?�Processz1Wrapper class around underlying C implementation.)�_cacher� r� � _procfs_pathrh c C s || _ d | _d | _t� | _d S rH )rh r� r� r r� )r� rh r. r. r/ �__init__S s zProcess.__init__c C � | j �| � | j�| � d S rH )�_proc_basic_infoZcache_activate�
_proc_cred�r� r. r. r/ �
oneshot_enterY � zProcess.oneshot_enterc C r� rH )r� Zcache_deactivater� r� r. r. r/ � oneshot_exit] r� zProcess.oneshot_exitc C � t �| j| j�S rH )r- Zproc_basic_inforh r� r� r. r. r/ r� a � zProcess._proc_basic_infoc C r� rH )r- Z proc_credrh r� r� r. r. r/ r� f r� zProcess._proc_credc C s$ | j dkrdS t�| j | j��d�S )Nr Zswapper� )rh r- Z proc_namer� �rstripr� r. r. r/ r� k s
z Process.namec C s� | � � }|sdS |d }tjj|v r@tj�|�s%tj�tj�| �� |��}tj�|�r:tj�|�r:t� |tj
�r:|S tj� |�}tj d �
d�D ] }tj�tj�||��}tj�|�rft� |tj
�rf| S qHdS )Nr] r �PATH�:)�cmdliner? r� �sep�isabs�abspathr �cwd�isfile�access�X_OK�basename�environ�split)r� r� �exer� Z possible_exer. r. r/ r� r s.
�
� � ��z Process.exec C � t �| j�S rH )r- Z proc_argsrh r� r. r. r/ r� � � zProcess.cmdlinec C r� rH )r- Z proc_environrh r� r. r. r/ r� � r� zProcess.environc C � | � � td S )Nr �r� �
proc_info_mapr� r. r. r/ r � � zProcess.create_timec C r� )Nr r� r� r. r. r/ r � r� zProcess.num_threadsc C sX t �| j�}g }|D ]\}}}t�|||�}|�|� q
|s*t�| j� d| j� �� |S )N�/) r- r rh r Zpthreadr` r? �statr� )r� rn rb Z thread_id�utimeZstimere r. r. r/ �threads� s zProcess.threads�inetc C s. t || jd�}|st�| j� d| j� �� |S )N)rl r� )ri rh r? r� r� )r� rk r< r. r. r/ ri � s zProcess.net_connectionsc C r� rH )r- Zproc_priority_getrh r� r. r. r/ �nice_get� r� zProcess.nice_getc C s t �| j|�S rH )r- Zproc_priority_setrh )r� �valuer. r. r/ �nice_set� s zProcess.nice_setc C s | � � td | _| jS )Nr )r� r� r� r� r. r. r/ r � s z Process.ppidc C s" | � � \}}}}}}t�|||�S rH �r� r Zpuids)r� �real� effective�saved�_r. r. r/ �uids� � z Process.uidsc C s" | � � \}}}}}}t�|||�S rH r� )r� r� r� r� r� r. r. r/ �gids� r� z Process.gidsc C s t �| j| j�}tj|� S rH )r- Zproc_cpu_timesrh r� r Z pcputimes)r� �tr. r. r/ r= � s
zProcess.cpu_timesc C sP | � � td }|d@ d? |d@ B }t�d�D ]}t�|�j|kr%| S qd S )Nr! l � � i�� z /dev/**/*)r� r� �globr? r� �st_rdev)r� Zttydev�devr. r. r/ �terminal� s �zProcess.terminalc C sV | j }zt�|� d| j� d��}|�d�W S ty* t�|� d| j� �� Y dS w )Nr� z/cwdr] )r� r? �readlinkrh r� r� r� )r� Z procfs_path�resultr. r. r/ r� � s �z Process.cwdc C s2 | � � }|td d }|td d }t||�S )Nr i r )r� r� r" )r� r< r r r. r. r/ � memory_info� s
zProcess.memory_infoc C s | � � td }t�|d�S )Nr �?)r� r� �
PROC_STATUSESr� )r� �coder. r. r/ r � s zProcess.statusc C s� t jddt| j�gt jt jd�}|�� \}}dd� ||fD �\}}d|�� v r.t| j| j��t �
d|�}g }|D ]%\}}|� � }|� d�rK|d d � }|�� d
krRq8|�
t�|t|��� q8|S ) Nz/usr/bin/procfilesz-nrD c s rG rH rI r4 r. r. r/ rM rw z%Process.open_files.<locals>.<genexpr>zno such processz(\d+): S_IFREG.*name:(.*)\nz//r zcannot be retrieved)rN rO r� rh rP rQ �lowerr r� r{ �findallrT �
startswithr` r Z popenfiler} )r� rX rE rF Z procfilesrb rp r� r. r. r/ �
open_files s* �
�
zProcess.open_filesc C s, | j dkrdS tt�| j� d| j � d���S )Nr r� z/fd)rh rV r? r� r� r� r. r. r/ �num_fds s
zProcess.num_fdsc C s t jt�| j�� S rH )r Zpctxswr- Zproc_num_ctx_switchesrh r� r. r. r/ �num_ctx_switches � zProcess.num_ctx_switchesNc C s t �| j|| j�S rH )r Zwait_pidrh r� )r� �timeoutr. r. r/ �wait# r� z Process.waitc
C s^ z t �| j�\}}}}W n ty& } zt| j�s!t| j| j�|�� d }~ww t�||||�S rH ) r- r rh �OSErrorr� r r� r Zpio)r� �rc�wc�rb�wbr� r. r. r/ � io_counters) s
��zProcess.io_counters)r� rH )&�__name__�
__module__� __qualname__�__doc__� __slots__r� r� r� r� r r� r� r� r� r� r� r r � HAS_THREADSr� ri r� r� r r� r� r= r� r� r� Zmemory_full_infor r� r� r� r� �HAS_PROC_IO_COUNTERSr� r. r. r. r/ r� N sz
�r� )F)rf )]r� r� r� r? r{ rN rK � collectionsr r] r r r r- r r r r
r r r
r r r Z__extra__all__�hasattrr� ZHAS_NET_IO_COUNTERSr� Z getpagesizeZ PAGE_SIZEZAF_LINKZSIDLZ STATUS_IDLEZSZOMBZ
STATUS_ZOMBIEZSACTIVEZSTATUS_RUNNINGZSSWAPZSSTOPZSTATUS_STOPPEDr� ZTCPS_ESTABLISHEDZCONN_ESTABLISHEDZ
TCPS_SYN_SENTZ
CONN_SYN_SENTZ
TCPS_SYN_RCVDZ
CONN_SYN_RECVZTCPS_FIN_WAIT_1ZCONN_FIN_WAIT1ZTCPS_FIN_WAIT_2ZCONN_FIN_WAIT2ZTCPS_TIME_WAITZCONN_TIME_WAITZ TCPS_CLOSEDZ
CONN_CLOSEZTCPS_CLOSE_WAITZCONN_CLOSE_WAITZ
TCPS_LAST_ACKZ
CONN_LAST_ACKZ TCPS_LISTENZ CONN_LISTENZ TCPS_CLOSINGZ CONN_CLOSINGZPSUTIL_CONN_NONEZ CONN_NONErj �dictr� r" Zpfullmemr# r& r0 r2 r= r9 rB rZ r[ Zdisk_io_countersr_ r^ rz r ri r� r� r� r� r� r� r� r. r. r. r/ �<module> s�
� ��
+