File: //opt/saltstack/salt/lib/python3.10/site-packages/psutil/__pycache__/_psaix.cpython-310.pyc
o
�N�g{H � @ 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 ddl
mZ ddlmZ ddlm Z ddlm Z ddlm Z dgZ e e
d�Z!e e
d�Z"e e
d�Z#e�$� Z%ej&Z&e
j'e
j(e
j)e
j*e
j+e
j,e
j-e
j,e
j.e
j/iZ0e
j1e
j2e
j3e
j4e
j5e
j6e
j7e
j8e
j9e
j:e
j;e
j<e
j=e
j>e
j?e
j@e
jAe
jBe
jCe
jDe
jEe
jFe
jGe
jHi ZIeJdddd d d d d d!�ZKed"d#d$g�ZLeLZMed%g d&��ZNed'g d(��ZOd)d*� ZPd+d,� ZQd-d.� ZRd/d0� ZSd1d2� ZTd3d4� ZUd5d6� ZVe
jWZWe jXZXdKd8d9�ZYejZZZe"�r@e
j[Z[dLd;d<�Z\d=d>� Z]d?d@� Z^dAdB� Z_dCdD� Z`dEdF� ZadGdH� ZbG dIdJ� dJec�ZddS )Mz AIX platform implementation.� N)�
namedtuple� )�_common)�_psposix)� _psutil_aix)�
_psutil_posix)� AccessDenied)�conn_to_ntuple)�get_procfs_path)�memoize_when_activated)�NIC_DUPLEX_FULL)�NIC_DUPLEX_HALF)�NIC_DUPLEX_UNKNOWN)�
NoSuchProcess)�
usage_percent)�
ZombieProcess)�FileNotFoundError)�PermissionError)�ProcessLookupError)�PY3Z 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)�totalZ available�percent�used�freec C s4 t �� \} }}}}t| | | dd�}t| ||||�S )Nr �Zround_)�cextZ virtual_memr r+ )r, Zavailr/ ZpinnedZinuser- � r2 �A/opt/saltstack/salt/lib/python3.10/site-packages/psutil/_psaix.py�virtual_memoryj s r4 c C s: t �� \} }}}| | }t|| dd�}t�| |||||�S )z=Swap system memory as a (total, used, free, sin, sout) tuple.r r0 )r1 Zswap_memr r Zsswap)r, r/ �sinZsoutr. r- r2 r2 r3 � swap_memoryp s r6 c C s t �� } tdd� t| � D �� S )z-Return system-wide CPU times as a named tuplec S � g | ]}t |��qS r2 )�sum��.0�xr2 r2 r3 �
<listcomp>� � z cpu_times.<locals>.<listcomp>)r1 �
per_cpu_timesr( �zip��retr2 r2 r3 � cpu_times} s rB c C s t �� } dd� | D �S )z5Return system per-CPU times as a list of named tuplesc S s g | ]}t |� �qS r2 )r( r9 r2 r2 r3 r< � r= z!per_cpu_times.<locals>.<listcomp>)r1 r> r@ r2 r2 r3 r> � s r> 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�
ValueErrorr2 r2 r2 r3 �cpu_count_logical� s
�rG c C sr d} t j| dt jt jd�}|�� \}}tr dd� ||fD �\}}|jdkr-td| |f ��|�� �� }t |�p8d S )Nzlsdev -Cc processorT)�shell�stdout�stderrc S � g | ] }|� tjj��qS r2 ��decode�sysrI �encodingr9 r2 r2 r3 r< � � �z&cpu_count_physical.<locals>.<listcomp>r z%r command error
%s)
�
subprocess�Popen�PIPE� communicater �
returncode� RuntimeError�strip�
splitlines�len)�cmd�prI rJ Z
processorsr2 r2 r3 �cpu_count_physical� s �
�
r\ c C s t �� \} }}}t�| |||�S )z*Return various CPU stats as a named tuple.)r1 � cpu_statsr Z scpustats)Z ctx_switchesZ
interruptsZsoft_interruptsZsyscallsr2 r2 r3 r] � s �r] Fc C sh g }t �� }|D ])}|\}}}}|dkrd}| s t|�js qd }} t�|||||| �}
|�|
� q|S )z Return system disk partitions.Znone� N)r1 �disk_partitions�
disk_usager, r Z sdiskpart�append) �all�retlistZ
partitions� partitionZdeviceZ
mountpointZfstype�optsZmaxfileZmaxpath�ntupler2 r2 r3 r_ � s
� r_ ���c C s� t j}| |vrtd| d�dd� |D ��f ��t j| \}}t�|�}g }|D ],}|\}} }
} } }
}| |vr7q'|
|vr<q't|| |
| | |
t|dkrJ|ndd�}|�|� q'|S )z�Return socket connections. If pid == -1 return system-wide
connections (as opposed to connections opened by one process only).
z+invalid %r kind argument; choose between %sz, c S r7 r2 )�reprr9 r2 r2 r3 r< � r= z#net_connections.<locals>.<listcomp>rg N��pid) r Z conn_tmaprF �joinr1 �net_connectionsr � TCP_STATUSESra )�kind�_pidZcmapZfamilies�types�rawlistrA �item�fdZfamZtype_�laddr�raddrr% rj �ntr2 r2 r3 rl � s& �
� rl c C s� t td�} tdd� t� D ��}i }|D ]X}t�|�\}}d}d}tjdd|gtjtjd�}|� � \} }
t
r@d d� | |
fD �\} }
|j dkr[t �
d
| �} | d ur[t| �d ��}| �d
�}| �|t�}t�||||�||< q|S )z)Get NIC stats (isup, duplex, speed, mtu).)�FullZHalfc S s g | ]}|d �qS )r r2 r9 r2 r2 r3 r< � r= z net_if_stats.<locals>.<listcomp>r^ r z/usr/bin/entstatz-d�rI rJ c S rK r2 rL r9 r2 r2 r3 r< � rP z"Running: (\d+) Mbps.*?(\w+) DuplexNr r )r r
�set� net_if_addrsr1 � net_if_statsrQ rR rS rT r rU �re�search�int�group�getr r Z snicstats) Z
duplex_map�namesrA �nameZisupZmtuZduplexZspeedr[ rI rJ Z re_resultr2 r2 r3 r{ � s6 � �
�
�
r{ c C s t �� S )z:The system boot time expressed in seconds since the epoch.)r1 � boot_timer2 r2 r2 r3 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)r1 �usersr Zsuserra ) rc rq r� rr r) Ztty�hostnameZtstampZ user_processrj rv r2 r2 r3 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 r2 )�isdigitr~ r9 r2 r2 r3 r< - s zpids.<locals>.<listcomp>)rD �listdirr
r2 r2 r2 r3 �pids+ s r� c C s t j�t j�t� t| �d��S )z&Check for the existence of a unix pid.Zpsinfo)rD �path�existsrk r
�strri r2 r2 r3 �
pid_exists0 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 sp z � | g|�R i |��W S t tfy* t| j�s!t| j| j��t| j| j| j�� ty7 t | j| j��w �N)
r r r� rj r �_namer �_ppidr r )�self�args�kwargs��funr2 r3 �wrapper9 s
�z wrap_exceptions.<locals>.wrapper)� functools�wraps)r� r� r2 r� r3 �wrap_exceptions5 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.)rj r� r� � _procfs_path�_cachec C s || _ d | _d | _t� | _d S r� )rj r� r� r
r� )r� rj r2 r2 r3 �__init__O s zProcess.__init__c C � | j �| � | j�| � d S r� )�_proc_basic_infoZcache_activate�
_proc_cred�r� r2 r2 r3 �
oneshot_enterU � zProcess.oneshot_enterc C r� r� )r� Zcache_deactivater� r� r2 r2 r3 � oneshot_exitY r� zProcess.oneshot_exitc C � t �| j| j�S r� )r1 Zproc_basic_inforj r� r� r2 r2 r3 r� ] � zProcess._proc_basic_infoc C r� r� )r1 Z proc_credrj r� r� r2 r2 r3 r� b r� zProcess._proc_credc C s$ | j dkrdS t�| j | j��d�S )Nr Zswapper� )rj r1 Z proc_namer� �rstripr� r2 r2 r3 r� g 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�:)�cmdlinerD r� �sep�isabs�abspathrk �cwd�isfile�access�X_OK�basename�environ�split)r� r� �exer� Z possible_exer2 r2 r3 r� n s,
� � ��z Process.exec C � t �| j�S r� )r1 Z proc_argsrj r� r2 r2 r3 r� � � zProcess.cmdlinec C r� r� )r1 Z proc_environrj r� r2 r2 r3 r� � r� zProcess.environc C � | � � td S )Nr" �r� �
proc_info_mapr� r2 r2 r3 r" � � zProcess.create_timec C r� )Nr$ r� r� r2 r2 r3 r$ � r� zProcess.num_threadsc C sV t �| j�}g }|D ]\}}}t�|||�}|�|� q
|s)t�d| j| jf � |S )N�%s/%s) r1 r rj r Zpthreadra rD �statr� )r� rq rc Z thread_id�utimeZstimerf r2 r2 r3 �threads� s zProcess.threads�inetc C s, t || jd�}|st�d| j| jf � |S )N)ro r� )rl rj rD r� r� )r� rn rA r2 r2 r3 � connections� s zProcess.connectionsc C r� r� )�
cext_posix� getpriorityrj r� r2 r2 r3 �nice_get� r� zProcess.nice_getc C s t �| j|�S r� )r� � setpriorityrj )r� �valuer2 r2 r3 �nice_set� s zProcess.nice_setc C s | � � td | _| jS )Nr )r� r� r� r� r2 r2 r3 r � s z Process.ppidc C s" | � � \}}}}}}t�|||�S r� �r� r Zpuids)r� �real� effective�saved�_r2 r2 r3 �uids� � z Process.uidsc C s" | � � \}}}}}}t�|||�S r� r� )r� r� r� r� r� r2 r2 r3 �gids� r� z Process.gidsc C s t �| j| j�}tj|� S r� )r1 Zproc_cpu_timesrj r� r Z pcputimes)r� rB r2 r2 r3 rB � 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� �globrD r� �st_rdev)r� Zttydev�devr2 r2 r3 �terminal� s �zProcess.terminalc C sP | j }zt�d|| jf �}|�d�W S ty' t�d|| jf � Y d S w )Nz %s/%s/cwd�/r� )r� rD �readlinkrj r� r r� )r� Z procfs_path�resultr2 r2 r3 r� � s �z Process.cwdc C s2 | � � }|td d }|td d }t||�S )Nr i r! )r� r� r' )r� rA r r! r2 r2 r3 � memory_info� s
zProcess.memory_infoc C s | � � td }t�|d�S )Nr% �?)r� r� �
PROC_STATUSESr� )r� �coder2 r2 r3 r% � s zProcess.statusc C s� t jddt| j�gt jt jd�}|�� \}}tr#dd� ||fD �\}}d|�� v r0t| j| j ��t
� d|�}g }|D ]%\}}|� � }|�
d�rM|d d � }|�� d
krTq:|�t�|t|��� q:|S ) Nz/usr/bin/procfilesz-nrx c S rK r2 rL r9 r2 r2 r3 r< � rP z&Process.open_files.<locals>.<listcomp>zno such processz (\d+): S_IFREG.*\s*.*name:(.*)\nz//r zcannot be retrieved)rQ rR r� rj rS rT r �lowerr r� r| �findallrW �
startswithra r Z popenfiler~ )r� r[ rI rJ Z procfilesrc rs r� r2 r2 r3 �
open_files� s( �
�
zProcess.open_filesc C s( | j dkrdS tt�d| j| j f ��S )Nr z%s/%s/fd)rj rY rD r� r� r� r2 r2 r3 �num_fds s
zProcess.num_fdsc C s t jt�| j�� S r� )r Zpctxswr1 Zproc_num_ctx_switchesrj r� r2 r2 r3 �num_ctx_switches s
�zProcess.num_ctx_switchesNc C s t �| j|| j�S r� )r Zwait_pidrj r� )r� �timeoutr2 r2 r3 �wait s z Process.waitc C sR z t �| j�\}}}}W n ty t| j�s t| j| j��� w t�||||�S r� ) r1 r rj �OSErrorr� r r� r Zpio)r� �rcZwc�rb�wbr2 r2 r3 � io_counters s
�zProcess.io_counters)r� r� )&�__name__�
__module__� __qualname__�__doc__� __slots__r� r� r� r� r r� r� r� r� r� r� r" r$ � HAS_THREADSr� r� r� r� r r� r� rB r� r� r� Zmemory_full_infor% r� r� r� r� �HAS_PROC_IO_COUNTERSr� r2 r2 r2 r3 r� J sz
�r� )F)rg )er� r� r� rD r| rQ rN � collectionsr r^ r r r r1 r r� r r r
r r r
r r r r Z_compatr 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_NONErm �dictr� r' Zpfullmemr( r+ r4 r6 rB r> rG r\ r] Zdisk_io_countersr` r_ rz r rl r{ r� r� r� r� r� �objectr� r2 r2 r2 r3 �<module> s�
� ��
%