U
�=�_�c � @ sL d Z ddlZddlZddlZddlZddlZddlZddlmZ ddlm Z ddl
m Z ddl
m Z ddl
m
Z 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 ddl mZ ddl mZ ddl m Z ddl m Z ddl m Z ddl m Z ddl m!Z! ddd gZ"e�#� Z$ej%Z%ej&d kZ'd Z(d Z)ej*e j+ej,e j-ej.e j/ej0e j1ej2e j3ej4e j-ej5e j6iZ7ej8e j9ej:e j;ej<e j=ej>e j?ej@e jAejBe jCejDe jEejFe jGejHe jIejJe jKejLe jMejNe jOejPe(ejQe)iZReSddd d!d"d#d$d%d&d'd(d)d*� ZTed+d,d-d.d/g�ZUed0d,d-d1d2g�ZVed3d4d5d6d7d8g�ZWed9d:d;g�ZXeXZYed<d=d:d>d?g�ZZed@dAdB�[eZj\� �Z]dCdD� Z^dEdF� Z_dGdH� Z`dIdJ� ZadKdL� ZbdMdN� ZcdOdP� ZdejeZee jfZfdedRdS�ZgejhZhejiZidfdUdV�ZjdWdX� ZkdYdZ� Zld[d\� Zmd]d^� Znd_d`� Zodadb� ZpG dcdd� ddeq�ZrdS )gz'Sun OS Solaris platform implementation.� N)�
namedtuple)�AF_INET� )�_common)�_psposix)�
_psutil_posix)�
_psutil_sunos)� AccessDenied)�AF_INET6)�debug)�get_procfs_path)�
isfile_strict)�memoize_when_activated)�
NoSuchProcess)�sockfam_to_enum)�socktype_to_enum)�
usage_percent)�
ZombieProcess)�b)�FileNotFoundError)�PermissionError)�ProcessLookupError)�PY3� CONN_IDLE�
CONN_BOUNDZ PROCFS_PATHl ZIDLEZBOUND� � � � � � � � �
� ) �ppid�rss�vms� create_time�nice� num_threads�status�ttynr�uid�euid�gid�egid� scputimes�user�systemZidleZiowait� pcputimes�
children_user�children_system�svmem�totalZ available�percent�used�free�pmemr& r' �
pmmap_grouped�pathZ anonymous�locked� pmmap_extz addr perms � c C sF t �d�t } t �d�t }}| | }t|| dd�}t| ||||�S )z Report virtual memory metrics.�
SC_PHYS_PAGES�SC_AVPHYS_PAGESr �Zround_)�os�sysconf� PAGE_SIZEr r7 )r8 r; Zavailr: r9 � rH �B/opt/alt/python38/lib64/python3.8/site-packages/psutil/_pssunos.py�virtual_memory{ s
rJ c
C s
t �� \} }tjddtjd ddgtjd�}|�� \}}trL|� t
j j �}|j
dkrdtd|j
��|�� �d �d
d � }|s�td ��d }}|D ]D}|�� }|d
d� \} }
|tt| �d �7 }|tt|
�d �7 }q�|| } t| |d
d�} t�|| || | t |t �S )zReport swap memory metrics.z /usr/bin/envzPATH=/usr/sbin:/sbin:%s�PATHZswapz-l)�stdoutr z 'swap -l' failed (retcode=%s)�
r Nz no swap device(s) configuredr r i rD )�cextZswap_mem�
subprocess�PopenrE �environ�PIPE� communicater �decode�sysrL �encoding�
returncode� RuntimeError�strip�split�intr r ZsswaprG )
ZsinZsout�prL �stderr�linesr8 r; �line�t�fr: r9 rH rH rI � swap_memory� s: � ��
�rb c C s t �� } tdd� t| � D �� S )z-Return system-wide CPU times as a named tuplec S s g | ] }t |��qS rH )�sum��.0�xrH rH rI �
<listcomp>� s z cpu_times.<locals>.<listcomp>)rN �
per_cpu_timesr1 �zip��retrH rH rI � cpu_times� s rl c C s t �� } dd� | D �S )z5Return system per-CPU times as a list of named tuplesc S s g | ] }t |� �qS rH )r1 rd rH rH rI rg � s z!per_cpu_times.<locals>.<listcomp>)rN rh rj rH rH rI rh � s rh c C s( z t �d�W S tk
r" Y dS X dS )z0Return the number of logical CPUs in the system.�SC_NPROCESSORS_ONLNN)rE rF �
ValueErrorrH rH rH rI �cpu_count_logical� s ro c C s t �� S )z1Return the number of physical CPUs in the system.)rN Zcpu_count_physrH rH rH rI �cpu_count_physical� s rp c C s$ t �� \} }}}d}t�| |||�S )z*Return various CPU stats as a named tuple.r )rN � cpu_statsr Z scpustats)Z ctx_switchesZ
interruptsZsyscallsZtrapsZsoft_interruptsrH rH rI rq � s
�rq Fc C s� g }t �� }|D ]�}|\}}}}|dkr,d}| s~zt|�js@W qW n: tk
r| } z td||f � W Y �qW 5 d}~X Y nX d } }
t�||||| |
�} |�| � q|S )z Return system disk partitions.Znone� zskipping %r: %rN) rN �disk_partitions�
disk_usager8 �OSErrorr r Z sdiskpart�append) �all�retlistZ
partitions� partitionZdeviceZ
mountpointZfstypeZopts�errZmaxfileZmaxpathZntuplerH rH rI rs � s(
� rs ���c
C s t j�� }|dkr |�dd� | |krFtd| d�dd� |D ��f ��t j| \}}t�|�}t� }|D ]�}|\}} }
} } }
}| |kr�qh|
|kr�qh| t t
fkr�| r�t j | � } | r�t j | � } t |
}
t
| �} t|
�}
|dkr�t �|| |
| | |
|�}nt �|| |
| | |
�}|�|� qht|�S )z�Return socket connections. If pid == -1 return system-wide
connections (as opposed to connections opened by one process only).
Only INET sockets are returned (UNIX are not).
r{ �unixr z+invalid %r kind argument; choose between %sz, c S s g | ] }t |��qS rH )�reprrd rH rH rI rg s z#net_connections.<locals>.<listcomp>)r Z conn_tmap�copy�poprn �joinrN �net_connections�setr r
�addr� TCP_STATUSESr r Zsconn�pconn�add�list)�kind�_pidZcmapZfamilies�types�rawlistrk �item�fdZfamZtype_ZladdrZraddrr+ �pid�ntrH rH rI r� � s:
�
r� c C sR t �� } | �� D ]<\}}|\}}}}ttd�r8t�|�}t�||||�| |< q| S )z)Get NIC stats (isup, duplex, speed, mtu).� NicDuplex)rN � net_if_stats�items�hasattrr r� Z snicstats)rk �namer� ZisupZduplexZspeedZmturH rH rI r� ! s
r� c C s t �� S )z:The system boot time expressed in seconds since the epoch.)rN � boot_timerH rH rH rI r� 1 s r� c C s\ g } t �� }d}|D ]B}|\}}}}}} |s.q||kr:d}t�||||| �}
| �|
� q| S )z:Return currently connected users as a list of namedtuples.)z:0.0z:0� localhost)rN �usersr Zsuserrv ) rx r� r� r� r2 �ttyZhostnameZtstampZ user_processr� r� rH rH rI r� 6 s r� c C s dd� t �tt� ��D �S )z7Returns a list of PIDs currently running on the system.c S s g | ]}|� � rt|��qS rH )�isdigitr[ rd rH rH rI rg P s zpids.<locals>.<listcomp>)rE �listdirr r rH rH rH rI �pidsN s r� c C s
t �| �S )z&Check for the existence of a unix pid.)r �
pid_exists)r� rH rH rI r� S 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� z� | f|�|�W S t tfk
rV t| j�s@t| j| j��nt| j| j| j��Y n\ tk
rv t | j| j��Y n< t
k
r� | jdkr�dt � kr�t | j| j��n� � Y nX d S �Nr ) r r r� r� r �_namer �_ppidr r ru r� )�self�args�kwargs��funrH rI �wrapper\ s
z wrap_exceptions.<locals>.wrapper)� functools�wraps)r� r� rH r� rI �wrap_exceptionsX s r� c @ s� e Zd ZdZdddddgZdd� Zd d
� Zd d � Zd
d� Ze e
dd� ��Z e e
dd� ��Z e e
dd� ��Z
e dd� �Ze dd� �Ze dd� �Ze dd � �Ze d d � �Ze d d � �Ze d!d"� �Ze d#d$� �Ze d%d&� �Ze d'd(� �Ze d)d*� �Ze d+d,� �Ze d-d.� �Ze d/d0� �Ze d1d2� �Z e d3d4� �Z e Z e d5d6� �Z e d7d8� �Z e d9d:� �Z!d;d<� Z"e dLd>d?��Z#e$d@dA�Z%e$d@dB�Z&e dCdD� �Z'e dEdF� �Z(e dGdH� �Z)e dMdJdK��Z*dIS )N�Processz1Wrapper class around underlying C implementation.r� r� r� � _procfs_path�_cachec C s || _ d | _d | _t� | _d S �N)r� r� r� r r� )r� r� rH rH rI �__init__y s zProcess.__init__c C s t �d| j| jf � dS )z+Raise NSP if the process disappeared on us.�%s/%sN)rE �statr� r� �r� rH rH rI �
_assert_alive s zProcess._assert_alivec C s( | j �| � | j�| � | j�| � d S r� )�_proc_name_and_argsZcache_activate�_proc_basic_info�
_proc_credr� rH rH rI �
oneshot_enter� s zProcess.oneshot_enterc C s( | j �| � | j�| � | j�| � d S r� )r� Zcache_deactivater� r� r� rH rH rI � oneshot_exit� s zProcess.oneshot_exitc C s t �| j| j�S r� )rN Zproc_name_and_argsr� r� r� rH rH rI r� � s zProcess._proc_name_and_argsc C sT | j dkr,tj�d| j| j f �s,t| j ��t�| j | j�}t|�tt �ksPt
�|S )Nr z %s/%s/psinfo) r� rE r> �existsr� r rN Zproc_basic_info�len�
proc_info_map�AssertionError)r� rk rH rH rI r� � s
�
zProcess._proc_basic_infoc C s t �| j| j�S r� )rN Z proc_credr� r� r� rH rH rI r� � s zProcess._proc_credc C s | � � d S r� )r� r� rH rH rI r� � s z Process.namec C s: zt �d| j| jf �W S tk
r, Y nX | �� dS )Nz%s/%s/path/a.outrr )rE �readlinkr� r� ru �cmdliner� rH rH rI �exe� s �z Process.exec C s | � � d �d�S )Nr rA )r� rZ r� rH rH rI r� � s zProcess.cmdlinec C s t �| j| j�S r� )rN Z proc_environr� r� r� rH rH rI rQ � s zProcess.environc C s | � � td S )Nr( �r� r� r� rH rH rI r( � s zProcess.create_timec C s | � � td S )Nr* r� r� rH rH rI r* � s zProcess.num_threadsc C s | � � td S )Nr) r� r� rH rH rI �nice_get� s zProcess.nice_getc C s& | j dkrt| j | j��t�| j |�S )N)r r )r� r r� �
cext_posix� setpriority)r� �valuerH rH rI �nice_set� s
zProcess.nice_setc C s | � � td | _| jS )Nr% )r� r� r� r� rH rH rI r% � s z Process.ppidc C s` z| � � \}}}}}}W n8 tk
rP | �� td }| �� td }d }Y nX t�|||�S )Nr- r. �r� r r� r� r Zpuids)r� �real� effective�saved�_rH rH rI �uids� s
z Process.uidsc C s` z| � � \}}}}}}W n8 tk
rP | �� td }| �� td }d }Y nX t�|||�S )Nr/ r0 r� )r� r� r� r� r� rH rH rI �gids� s
z Process.gidsc
C sZ zt �| j| j�}W n: tk
rN } z |jtjkr<ts<d}n� W 5 d }~X Y nX tj |� S )N)� r� r� r� )
rN Zproc_cpu_timesr� r� ru �errno� EOVERFLOW� IS_64_BITr r4 )r� �timesrz rH rH rI rl � s zProcess.cpu_timesc C s t �| j| j�S r� )rN Z proc_cpu_numr� r� r� rH rH rI �cpu_num s zProcess.cpu_numc C s| | j }d}t| �� td �}|tjkrldD ]>}z t�d|| j|f �W S t k
rh d}Y q,Y q,X q,|rx| �
� d S )NFr, )r r r � z
%s/%d/path/%dT) r� r� r� r� rN ZPRNODEVrE r� r� r r� )r� � procfs_path�
hit_enoentr� rf rH rH rI �terminal s �
�
zProcess.terminalc C sL | j }zt�d|| jf �W S tk
rF t�d|| jf � Y d S X d S )Nz%s/%s/path/cwdr� )r� rE r� r� r r� )r� r� rH rH rI �cwd s z Process.cwdc C s2 | � � }|td d }|td d }t||�S )Nr& i r' )r� r� r< )r� rk r& r' rH rH rI � memory_info# s zProcess.memory_infoc C s | � � td }t�|d�S )Nr+ �?)r� r� �
PROC_STATUSES�get)r� �coderH rH rI r+ , s zProcess.statusc
C s� | j }g }t�d|| jf �}d}|D ]�}t|�}zt�| j||�\}}W nT tk
r� } z6|jtj krtt
stW Y � q&|jtj kr�d}W Y �q&� W 5 d }~X Y q&X t �
|||�} |�| � q&|r�| �� |S )Nz %s/%d/lwpFT)r� rE r� r� r[ rN Zquery_process_thread�EnvironmentErrorr� r� r� �ENOENTr Zpthreadrv r� )
r� r� rk Ztidsr� �tid�utimeZstimerz r� rH rH rI �threads2 s0 � zProcess.threadsc C s� g }d}| j }d|| jf }t�d|| jf �D ]h}tj�||�}tj�|�r0zt�|�}W n tk
rx d}Y q0Y q0X t |�r0|�
t � |t
|��� q0|r�| �� |S )NFz
%s/%d/pathz%s/%d/fdT)r� r� rE r� r> r� �islinkr� r r
rv r Z popenfiler[ r� )r� rx r� r� Zpathdirr� r> �filerH rH rI �
open_filesS s"
zProcess.open_filesc c s( d| }t j|dt jt jd�}|�� \}}trDdd� ||fD �\}}|jdkr�d|�� krht| j| j ��d|�� kr�t
| j| j ��t d ||f ��|� d
�d d � }t
|�D ]v\}}|�� }|�d
�r�|� dd �d } ||d �� }
|
dkr�tj}
n|
dk�rtj}
nd}
dtj|
| dtjfV q�d S )z<Get UNIX sockets used by process by parsing 'pfiles' output.z pfiles %sT)�shellrL r] c S s g | ]}|� tjj��qS rH )rT rU rL rV rd rH rH rI rg q s �z-Process._get_unix_sockets.<locals>.<listcomp>r zpermission deniedzno such processz%r command error
%srM r Nzsockname: AF_UNIXrA � SOCK_STREAM�
SOCK_DGRAMr{ rr )rO rP rR rS r rW �lowerr r� r� r rX rZ � enumerate�lstrip�
startswithrY �socketr� r� ZAF_UNIXr � CONN_NONE) r� r� �cmdr\ rL r] r^ �ir_ r> �typerH rH rI �_get_unix_socketsh s6 � �
zProcess._get_unix_sockets�inetc C sP t || jd�}|s(t�d| j| jf � |dkrL|�dd� | �| j�D �� |S )N)r� r� )rw r| c S s g | ]}t j|� �qS rH )r r� )re ZconnrH rH rI rg � s z'Process.connections.<locals>.<listcomp>)r� r� rE r� r� �extendr� )r� r� rk rH rH rI � connections� s
�zProcess.connectionsZmmapzpath rss anon lockedz addr perms path rss anon lockedc C s$ dd� }| j }g }zt�| j|�}W n@ tk
rd } z"|jtjkrRtsRg W Y �S � W 5 d }~X Y nX d}|D ]�}|\}} }
} } }
}||| �}| �d�s�zt �
d|| j| f �} W nF tk
r� } z(|jtj kr�d|| j| f } d}n� W 5 d }~X Y nX |� ||
| | |
|f� qn|�r | �
� |S )Nc S s0 dt | �dd � �d�t |�dd � �d�f S )Nz%s-%sr �L)�hexrY )�start�endrH rH rI �toaddr� s �z#Process.memory_maps.<locals>.toaddrF�[z
%s/%s/path/%sT)r� rN Zproc_memory_mapsr� ru r� r� r� r� rE r� r� rv r� )r� r� r� rx r� rz r� r� r� ZaddrsizeZpermr� r& Zanonr? rH rH rI � memory_maps� s6
� zProcess.memory_mapsc C s t t�d| j| jf ��S )Nz%s/%s/fd)r� rE r� r� r� r� rH rH rI �num_fds� s zProcess.num_fdsc C s t jt�| j| j�� S r� )r ZpctxswrN Zproc_num_ctx_switchesr� r� r� rH rH rI �num_ctx_switches� s �zProcess.num_ctx_switchesNc C s t �| j|| j�S r� )r Zwait_pidr� r� )r� ZtimeoutrH rH rI �wait� s z Process.wait)r� )N)+�__name__�
__module__� __qualname__�__doc__� __slots__r� r� r� r� r� r r� r� r� r� r� r� rQ r( r* r� r� r% r� r� rl r� r� r� r� Zmemory_full_infor+ r� r� r� r� r Znt_mmap_groupedZ nt_mmap_extr� r� r� r� rH rH rH rI r� t s�
.
r� )F)r{ )sr r� r� rE r� rO rU � collectionsr r rr r r r r� r rN r r
r r r
r r r r r r Z_compatr r r r r Z__extra__all__Z getpagesizerG ZAF_LINK�maxsizer� r r ZSSLEEPZSTATUS_SLEEPINGZSRUNZSTATUS_RUNNINGZSZOMBZ
STATUS_ZOMBIEZSSTOPZSTATUS_STOPPEDZSIDLZ STATUS_IDLEZSONPROCZSWAITZSTATUS_WAITINGr� 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_NONEr� Z TCPS_IDLEZ
TCPS_BOUNDr� �dictr� r1 r4 r7 r< Zpfullmemr= r� �_fieldsr@ rJ rb rl rh ro rp rq Zdisk_io_countersrt rs Znet_io_countersZ net_if_addrsr� r� r� r� r� r� r� �objectr� rH rH rH rI �<module> s�
� ��
�
� � &
!
%