File: //proc/self/root/usr/local/lib64/python3.9/site-packages/psutil/__pycache__/_common.cpython-39.pyc
a
q�dg+t �
@ sh d Z ddlmZ ddlmZ ddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddlmZ ddl mZ ddl mZ ddl mZ zdd l mZ W n ey� dZY n0 zdd
l mZ W n ey� dZY n0 e jd d kZe�r
ddlZndZee�d ��Ze� Z g d
�Z ej dkZ ej dkZ e j!�"d�Z#e j!�"d�Z$e$Z%e j!�"d�Z&e j!�"d�Z'e j!�"d�Z(e&�p�e'�p�e(Z)e j!�"d�Z*e j!�"d�Z+dZ,dZ-dZ.dZ/dZ0d Z1d Z2d Z3d Z4d Z5d!Z6d"Z7d#Z8d$Z9d%Z:d&Z;d'Z<d(Z=d)Z>d*Z?d+Z@d,ZAd-ZBd.ZCd/ZDd0ZEedu �r&d1ZFd2ZGdZHn G d3d4� d4ejI�ZJeK� �LeJjM� edu �rZd5ZNd6ZOn G d7d8� d8ejI�ZPeK� �LePjM� e �Q� ZRe�s�d9ZSn0z e �T� ZSW n" eU�y� e �r�d:nd9ZSY n0 ed;g d<��ZVed=g d>��ZWed?g d@��ZXedAg dB��ZYedCg dD��ZZedEg dF��Z[edGg dH��Z\edIg dJ��Z]edKg dL��Z^edMg dN��Z_edOg dP��Z`edQg dR��ZaedSg dT��ZbedUdVdWg�ZcedXg dY��ZdedZd[d\g�Zeed]g d^��Zfed_g d`��Zgedag d`��Zhedbg dc��Ziedddedfg�Zjedgdhdig�Zkedjg dk��Zledldmdng�Zmeeegeegfeegegfegegfeegegfegegfeegeegfegeegfegeegfdo�Znedu�r�en�Legegfegegfdp�� edu�r�en�Ldqegeegfi� G drds� dseo�ZpG dtdu� duep�ZqG dvdw� dweq�ZrG dxdy� dyep�ZsG dzd{� d{ep�Zte�rBeuevew��r.evd| Zxn
eyevd|�Zxexd}� nd~d� Zzd�d�d��Z{d�d�� Z|d�d�� Z}d�d�� Z~d�d�� Ze|d�d�� �Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�d��Z�d�d�� Z�G d�d�� d��Z�d�d�� Z�e�� Z�e�j�e�_�e�j�e�_�d�Z�d�d�� Z�d�d�� Z�e e�fd�d��Z�e fd�d��Z�d�d�d��Z�d�d�� Z�e�r&d�d�� Z�nd�d�� Z�e|e j�fd�d���Z�d�d�d��Z�dd�e j�fd�d��Z�d�d�� Z�dS )�z9Common objects shared by __init__.py and _ps*.py modules.� )�division)�print_functionN)�
namedtuple)�AF_INET)�
SOCK_DGRAM)� SOCK_STREAM)�AF_INET6)�AF_UNIX� � PSUTIL_DEBUG)R�FREEBSD�BSD�LINUX�NETBSD�OPENBSD�MACOS�OSX�POSIX�SUNOS�WINDOWS�
CONN_CLOSE�CONN_CLOSE_WAIT� CONN_CLOSING�CONN_ESTABLISHED�CONN_FIN_WAIT1�CONN_FIN_WAIT2�
CONN_LAST_ACK� CONN_LISTEN� CONN_NONE�
CONN_SYN_RECV�
CONN_SYN_SENT�CONN_TIME_WAIT�NIC_DUPLEX_FULL�NIC_DUPLEX_HALF�NIC_DUPLEX_UNKNOWN� STATUS_DEAD�STATUS_DISK_SLEEP� STATUS_IDLE�
STATUS_LOCKED�STATUS_RUNNING�STATUS_SLEEPING�STATUS_STOPPED�STATUS_SUSPENDED�STATUS_TRACING_STOP�STATUS_WAITING�STATUS_WAKE_KILL�
STATUS_WAKING�
STATUS_ZOMBIE�
STATUS_PARKED�ENCODING�
ENCODING_ERRSr �pconn� pcputimes�pctxsw�pgids�pio�pionice� popenfile�pthread�puids�sconn� scpustats�sdiskio� sdiskpart�
sdiskusage�snetio�snicaddr� snicstats�sswap�suser� conn_tmap�deprecated_method�
isfile_strict�memoize�parse_environ_block�path_exists_strict�
usage_percent�
supports_ipv6�sockfam_to_enum�socktype_to_enum� wrap_numbers� open_text� open_binary�cat�bcat� bytes2human�conn_to_ntuple�debug�hilite�term_supports_colors� print_color�posix�nt�linux�darwin)ZfreebsdZ midnightbsdZopenbsdZnetbsd)�sunos�solaris�aix�runningZsleepingz
disk-sleep�stoppedz tracing-stopZzombieZdeadz wake-killZwaking�idle�lockedZwaitingZ suspendedZparkedZ ESTABLISHEDZSYN_SENTZSYN_RECVZ FIN_WAIT1Z FIN_WAIT2Z TIME_WAITZCLOSEZ
CLOSE_WAITZLAST_ACKZLISTENZCLOSING�NONE� � c @ s e Zd ZdZdZdZdS )� NicDuplexri rj r N)�__name__�
__module__� __qualname__r" r# r$ � ro ro �:/usr/local/lib64/python3.9/site-packages/psutil/_common.pyrk � s rk ������c @ s e Zd ZdZdZdS )� BatteryTimerq rr N)rl rm rn �POWER_TIME_UNKNOWN�POWER_TIME_UNLIMITEDro ro ro rp rs � s rs �replace�surrogateescaperF )�total�used�free�percent�sinZsoutrB )rx ry rz r{ r@ )�
read_count� write_count�
read_bytes� write_bytesZ read_timeZ
write_timerA )ZdeviceZ
mountpointZfstype�optsrC )Z
bytes_sentZ
bytes_recvZ packets_sentZ packets_recvZerrinZerroutZdropinZdropoutrG )�nameZterminal�host�started�pidr> )�fd�family�type�laddr�raddr�statusr� rD )r� �address�netmask� broadcastZptprE )ZisupZduplex�speedZmtu�flagsr? )Z ctx_switchesZ
interruptsZsoft_interruptsZsyscalls�scpufreq)�current�min�max�shwtemp)�labelr� �high�critical�sbattery)r{ ZsecsleftZ
power_plugged�sfanr� r� r6 )�user�system�
children_user�children_systemr; �pathr� r< )�idZ user_timeZ system_timer= )�realZ effectiveZsavedr8 r9 )r} r~ r r� r: Zioclass�valuer7 Z voluntaryZ involuntaryr5 )r� r� r� r� r� r� �addr�ip�port)�allZtcpZtcp4ZudpZudp4ZinetZinet4Zinet6)Ztcp6Zudp6�unixc @ s, e Zd ZdZdZdd� Zdd� Zdd� Zd S )
�ErrorzQBase exception class. All other psutil exceptions inherit
from this one.
�psutilc C sH t �� }|D ]6}t| |d �}|r*|||< q |dkr |dkr |||< q |S )Nr� r )� collections� OrderedDict�getattr)�self�attrs�infor� r� ro ro rp � _infodict$ s
zError._infodictc C sP | � d�}|r,dd�dd� |�� D �� }nd }d�dd� t| dd �|fD ��S )
N)r� �ppidr� z(%s)�, c S s g | ]\}}d ||f �qS �z%s=%rro ��.0�k�vro ro rp �
<listcomp>3 � z!Error.__str__.<locals>.<listcomp>� c S s g | ] }|r|�qS ro ro )r� �xro ro rp r� 7 r� �msg� )r� �join�itemsr� �r� r� �detailsro ro rp �__str__. s
�z
Error.__str__c C s2 | � d�}d�dd� |�� D ��}d| jj|f S )N)r� r� r� �secondsr� r� c S s g | ]\}}d ||f �qS r� ro r� ro ro rp r� < r� z"Error.__repr__.<locals>.<listcomp>z
psutil.%s(%s))r� r� r� � __class__rl r� ro ro rp �__repr__9 s
zError.__repr__N)rl rm rn �__doc__r� r� r� ro ro ro rp r� s
r� c @ s& e Zd ZdZdZddd�Zdd� ZdS ) �
NoSuchProcesszXException raised when a process with a certain PID doesn't
or no longer exists.
r� Nc C s$ t �| � || _|| _|p d| _d S )Nzprocess no longer exists�r� �__init__r� r� r� �r� r� r� r� ro ro rp r� G s
zNoSuchProcess.__init__c C s | j | j| j| jffS �N�r� r� r� r� �r� ro ro rp �
__reduce__M s zNoSuchProcess.__reduce__)NN�rl rm rn r� r� r� ro ro ro rp r� @ s
r� c @ s& e Zd ZdZdZddd�Zdd� ZdS ) �
ZombieProcessa1 Exception raised when querying a zombie process. This is
raised on macOS, BSD and Solaris only, and not always: depending
on the query the OS may be able to succeed anyway.
On Linux all zombie processes are querable (hence this is never
raised). Windows doesn't have zombie processes.
r� Nc C s$ t �| |||� || _|p d| _d S )Nz"PID still exists but it's a zombie)r� r� r� r� )r� r� r� r� r� ro ro rp r� [ s zZombieProcess.__init__c C s | j | j| j| j| jffS r� )r� r� r� r� r� r� ro ro rp r� ` s zZombieProcess.__reduce__)NNNr� ro ro ro rp r� Q s
r� c @ s& e Zd ZdZdZddd�Zdd� ZdS ) � AccessDeniedz@Exception raised when permission to perform an action is denied.r� Nc C s$ t �| � || _|| _|p d| _d S )Nr� r� r� ro ro rp r� i s
zAccessDenied.__init__c C s | j | j| j| jffS r� r� r� ro ro rp r� o s zAccessDenied.__reduce__)NNNr� ro ro ro rp r� d s
r� c @ s& e Zd ZdZdZddd�Zdd� ZdS ) �TimeoutExpiredzWRaised on Process.wait(timeout) if timeout expires and process
is still alive.
r� Nc C s* t �| � || _|| _|| _d| | _d S )Nztimeout after %s seconds)r� r� r� r� r� r� )r� r� r� r� ro ro rp r� z s
zTimeoutExpired.__init__c C s | j | j| j| jffS r� )r� r� r� r� r� ro ro rp r� � s zTimeoutExpired.__reduce__)NNr� ro ro ro rp r� s s
r� �execzvdef raise_from(value, from_value):
try:
raise value from from_value
finally:
value = None
c C s | �d S r� ro )r� �
from_valuero ro rp �
raise_from� s r� c C sD zt | �| d }W n ty( Y dS 0 |dur<t||�}|S dS )z5Calculate percentage usage of 'used' against 'total'.�d g N)�float�ZeroDivisionError�round)ry rx Zround_�retro ro rp rN � s
rN c s2 t ���� �fdd��}� fdd�}i � ||_|S )a� A simple memoize decorator for functions supporting (hashable)
positional arguments.
It also provides a cache_clear() function for clearing the cache:
>>> @memoize
... def foo()
... return 1
...
>>> foo()
1
>>> foo.cache_clear()
>>>
It supports:
- functions
- classes (acts as a @singleton)
- staticmethods
- classmethods
It does NOT support:
- methods
c
s� | t t|�� ��f}z
� | W S ty~ z�| i |�� }� |< W n. tyt } zt|d ��W Y d }~n
d }~0 0 | Y S 0 d S r� )� frozenset�sortedr� �KeyError� Exceptionr� )�args�kwargs�keyr� �err��cache�funro rp �wrapper� s
zmemoize.<locals>.wrapperc s � � � dS )z Clear cache.N)�clearro )r� ro rp � cache_clear� s z memoize.<locals>.cache_clear)� functools�wrapsr� )r� r� r� ro r� rp rK � s rK c s6 t �� �� fdd��}dd� }dd� }||_||_|S )a� A memoize decorator which is disabled by default. It can be
activated and deactivated on request.
For efficiency reasons it can be used only against class methods
accepting no arguments.
>>> class Foo:
... @memoize
... def foo()
... print(1)
...
>>> f = Foo()
>>> # deactivated (default)
>>> foo()
1
>>> foo()
1
>>>
>>> # activated
>>> foo.cache_activate(self)
>>> foo()
1
>>> foo()
>>> foo()
>>>
c
s� z| j � }W n� ty^ z� | �W Y S tyX } zt|d ��W Y d }~n
d }~0 0 Y np ty� z � | �}W n. ty� } zt|d ��W Y d }~n
d }~0 0 z|| j � < W n ty� Y n0 Y n0 |S r� )�_cache�AttributeErrorr� r� r� )r� r� r� �r� ro rp r� � s" $ z'memoize_when_activated.<locals>.wrapperc S s
i | _ dS )zsActivate cache. Expects a Process instance. Cache will be
stored as a "_cache" instance attribute.
N)r� ��procro ro rp �cache_activate s z.memoize_when_activated.<locals>.cache_activatec S s z| ` W n ty Y n0 dS )zDeactivate and clear cache.N)r� r� r� ro ro rp �cache_deactivate s z0memoize_when_activated.<locals>.cache_deactivate)r� r� r� r� )r� r� r� r� ro r� rp �memoize_when_activated� s r� c
C sZ zt �| �}W n: tyH } z"|jtjtjfv r2� W Y d}~dS d}~0 0 t�|j�S dS )z�Same as os.path.isfile() but does not swallow EACCES / EPERM
exceptions, see:
http://mail.python.org/pipermail/python-dev/2012-June/120787.html.
NF)�os�stat�OSError�errno�EPERM�EACCES�S_ISREG�st_mode)r� �str� ro ro rp rJ s rJ c
C sR zt �| � W n: tyH } z"|jtjtjfv r2� W Y d}~dS d}~0 0 dS dS )z�Same as os.path.exists() but does not swallow EACCES / EPERM
exceptions. See:
http://mail.python.org/pipermail/python-dev/2012-June/120787.html.
NFT)r� r� r� r� r� r� )r� r� ro ro rp rM - s rM c C sv t jrtdu rdS zHt � tt j�} t�| �� | �d� W d � n1 sL0 Y W dS t jyp Y dS 0 dS )z2Return True if IPv6 is supported on this platform.NF)z::1r T)�socket�has_ipv6r r �
contextlib�closing�bind�error)�sockro ro rp rO < s (rO c C sv i }d}t }| �d|�}||kr"qr| �d||�}||krh| ||� }| |d |� }|r`|�� }|||< |d }q |S )zCParse a C environ block of environment variables into a dictionary.r � �=rj )r �find�upper)�datar� �posZWINDOWS_Znext_posZ equal_posr� r� ro ro rp rL J s
rL c C s4 t du r | S z t�| �W S ty. | Y S 0 dS )z�Convert a numeric socket family value to an IntEnum member.
If it's not a known member, return the numeric value itself.
N)�enumr� �
AddressFamily�
ValueError��numro ro rp rP f s rP c C s4 t du r | S z t�| �W S ty. | Y S 0 dS )zConvert a numeric socket type value to an IntEnum member.
If it's not a known member, return the numeric value itself.
N)r r� �
SocketKindr r ro ro rp rQ s s rQ c C s� |t jtfv r&|rt|� }|r&t|� }|t jkrJ|ttfv rJ|�|t�}nt}t|�}t|�}|du rxt | |||||�S t
| ||||||�S dS )z2Convert a raw connection tuple to a proper ntuple.N) r� r r r� r �getr rP rQ r5 r> )r� �fam�type_r� r� r� Z
status_mapr� ro ro rp rX � s rX c s � fdd�}|S )z�A decorator which can be used to mark a method as deprecated
'replcement' is the method name which will be called instead.
c s: d| j �f � | jd u r � | _t�| �� �fdd��}|S )Nz8%s() is deprecated and will be removed; use %s() insteadc s$ t j� tdd� t| ��|i |��S )Nri )�category�
stacklevel)�warnings�warn�DeprecationWarningr� )r� r� r� )r� � replacementro rp �inner� s z/deprecated_method.<locals>.outer.<locals>.inner)rl r� r� r� )r� r �r )r� rp �outer� s �
z deprecated_method.<locals>.outerro )r r ro r rp rI � s rI c @ sB e Zd ZdZdd� Zdd� Zdd� Zdd � Zdd d �Zd
d� Z d
S )� _WrapNumberszNWatches numbers so that they don't overflow and wrap
(reset to zero).
c C s t �� | _i | _i | _i | _d S r� )� threading�Lock�lockr� � reminders�
reminder_keysr� ro ro rp r� � s
z_WrapNumbers.__init__c C sX || j vsJ �|| jvs J �|| jvs*J �|| j |< t�t�| j|< t�t�| j|< d S r� )r� r r r� � defaultdict�int�set)r� �
input_dictr� ro ro rp � _add_dict� s
z_WrapNumbers._add_dictc C s\ | j | }t|�� �t|�� � }|D ]0}| j| | D ]}| j| |= q8| j| |= q&dS )z�In case the number of keys changed between calls (e.g. a
disk disappears) this removes the entry from self.reminders.
N)r� r# �keysr r )r� r$ r� �old_dictZ gone_keysZgone_key�remkeyro ro rp �_remove_dead_reminders� s
z#_WrapNumbers._remove_dead_remindersc
C s || j vr| �||� |S | �||� | j | }i }|D ]�}|| }z || }W n tyn |||< Y q8Y n0 g }tt|��D ]f} || }
|| } || f} |
| k r�| j| | | 7 < | j| | �| � |� |
| j| | � q�t
|�||< q8|| j |< |S )zlCache dict and sum numbers which overflow and wrap.
Return an updated copy of `input_dict`.
) r� r% r) r� �range�lenr r �add�append�tuple)
r� r$ r� r' Znew_dictr� Z input_tupleZ old_tuple�bits�iZ input_value� old_valuer( ro ro rp �run� s2
z_WrapNumbers.runNc C s| | j �b |du r0| j�� | j�� | j�� n*| j�|d� | j�|d� | j�|d� W d � n1 sn0 Y dS )z>Clear the internal cache, optionally only for function 'name'.N)r r� r� r r �pop)r� r� ro ro rp r� � s
z_WrapNumbers.cache_clearc C s: | j � | j| j| jfW d � S 1 s,0 Y dS )z5Return internal cache dicts as a tuple of 3 elements.N)r r� r r r� ro ro rp �
cache_info� s z_WrapNumbers.cache_info)N)
rl rm rn r� r� r% r) r2 r� r4 ro ro ro rp r � s '
r c C s6 t j� t �| |�W d � S 1 s(0 Y dS )z�Given an `input_dict` and a function `name`, adjust the numbers
which "wrap" (restart from zero) across different calls by adding
"old value" to "new value" and return an updated dict.
N)�_wnr r2 )r$ r� ro ro rp rR s rR i � c C s t | dtd�S )N�rb�� buffering)�open�FILE_READ_BUFFER_SIZE)�fnamero ro rp rT s rT c C s\ t st| td�S t| tttd�}z
t|_W n, ty< Y n tyV |�� � Y n0 |S )z�On Python 3 opens a file in text mode by using fs encoding and
a proper en/decoding errors handler.
On Python 2 this is just an alias for open(name, 'rt').
r7 )r8 �encoding�errors) �PY3r9 r: r3 r4 � _CHUNK_SIZEr� r� �close)r; �fobjro ro rp rS " s �
rS c C s� |t u r:|| ��}|�� W d � S 1 s.0 Y nRz6|| ��}|�� W d � W S 1 sd0 Y W n ttfy� | Y S 0 dS )z�Read entire file content and return it as a string. File is
opened in text mode. If specified, `fallback` is the value
returned in case of error, either if the file does not exist or
it can't be read().
N)�_DEFAULT�read�IOErrorr� )r; �fallback�_open�fro ro rp rU @ s
(
,rU c C s t | |td�S )z,Same as above but opens file in binary mode.)rE rF )rU rT )r; rE ro ro rp rV Q s rV �%(value).1f%(symbol)sc C s� d}i }t |dd� �D ] \}}d|d d > ||< qt|dd� �D ]2}t| �|| krFt| �|| }|t� S qF|t|d | d� S )z�Used by various scripts. See: http://goo.gl/zeJZl.
>>> bytes2human(10000)
'9.8K'
>>> bytes2human(100001221)
'95.4M'
) �B�K�M�G�T�P�E�Z�Yrj N�
r )�symbolr� )� enumerate�reversed�absr� �locals�dict)�n�format�symbols�prefixr0 �srS r� ro ro rp rW V s rW c C s t jd jS )z+Return updated psutil.PROCFS_PATH constant.r� )�sys�modulesZ PROCFS_PATHro ro ro rp �get_procfs_pathi s r` c C s | j ttd�S )N)r< r= )�decoder3 r4 �r] ro ro rp ra p s ra c C s | S r� ro rb ro ro rp ra u s c C s^ t jdkrdS z2dd l}| �� s$J �|�� |�d�dks>J �W n tyT Y dS 0 dS d S )Nr^ Tr �colorsF)r� r� �curses�isattyZ setuptermZtigetnumr� )�filerd ro ro rp r[ ~ s
r[ Fc C s� t � s
| S g }tddddddddd d
� }d |d < z || }W n& tyb td
t|�� � ��Y n0 |�|� |r||�d� dd�|�| f S )z*Return an highlighted version of 'string'.Z34Z33Z30Z32Z37Z36Z91Z35Z93) Zblue�brownZdarkgrey�greenZgreyZ lightblue�redZviolet�yellowZ29Nz#invalid color %r; choose between %s�1z [%sm%s[0m�;)r[ rX r� r �listr& r- r� )r] �color�bold�attrrc ro ro rp rZ � s2 � �
rZ c C s
t � st| |d� n�tr.tt| ||�|d� n�ddl}d}|jjj}|jjj}t ddddd�}||d< z || }W n* t
y� t d |t |�
� �f ��Y n0 |r�|dkr�|d
7 }|tju r�d nd } |j|_|| �}
||
|� zt| |d� W ||
|� n ||
|� 0 dS )
z$Print a colorized version of string.�rf r N� ri � � )rh ri rg rj z#invalid color %r; choose between %r� i�i����)r[ �printr rZ �ctypes�windll�Kernel32� GetStdHandle�SetConsoleTextAttributerX r� r rm r& r^ �stderr�c_ulong�restype) r] rn ro rf rw Z
DEFAULT_COLORrz r{ rc Z handle_id�handlero ro rp r\ � s8
� ��
r\ c C sn t rjddl}|�|�� j�\}}}}}t| t�rRt| ttt f�rJd| } nd| } t
d||| f t j d� dS )z@If PSUTIL_DEBUG env var is set, print a debug message to stderr.r Nz ignoring %sz ignoring %rzpsutil-debug [%s:%s]> %srq )
r �inspect� getframeinfo� currentframe�f_back�
isinstancer� r� rD �EnvironmentErrorrv r^ r| )r� r� r; �lineno�_�_lines�_indexro ro rp rY � s �
�rY )N)N)rH )NF)�r� �
__future__r r r� r� r� r� r� r� r� r^ r r r r r r r � ImportErrorr � version_infor> r �bool�getenvr �objectrB �__all__r� r r �platform�
startswithr r r r r r r
r ZAIXr) r* r& r+ r- r1 r% r/ r0 r' r( r. r, r2 r r r r r r! r r r r r r r" r# r$ �IntEnumrk �globals�update� __members__rt ru rs �getfilesystemencodingr3 r4 �getfilesystemencodeerrorsr� rF rB r@ rA rC rG r> rD rE r? r� r� r� r� r6 r; r< r= r8 r9 r: r7 r5 r� rH r� r� r� r� r� r� r� � __builtins__rX �exec_r� r� rN rK r� rJ rM rO rL rP rQ rX rI r rR r5 r� r4 r: rT rS rU rV rW r` ra �stdoutr[ rZ r\ rY ro ro ro rp �<module> sp
&
�������
�
�
#
-G
W
�
'