U
|f+t R @ s 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 ek
r dZY nX zdd
l mZ W n ek
r dZY nX e jd d kZerddlZndZeed Ze Z d
ddddddddddddddd d d d d d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;dd?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^gRZ ej d_kZ ej d`kZ e j!"daZ#e j!"dbZ$e$Z%e j!"dcZ&e j!"ddZ'e j!"deZ(e&p0e'p0e(Z)e j!"dfZ*e j!"dgZ+dhZ,diZ-djZ.dkZ/dlZ0dmZ1dnZ2doZ3dpZ4dqZ5drZ6dsZ7dtZ8duZ9dvZ:dwZ;dxZd{Z?d|Z@d}ZAd~ZBdZCdZDdZEedkrdZFdZGdZHn G dd dejIZJeK LeJjM edkrdZNdZOn G dd dejIZPeK LePjM e Q ZRes2dZSn2z e T ZSW n$ eUk
rb e rZdndZSY nX edHddddddgZVedDddddgZWedBddddddgZXedCddddgZYedEddddddddgZZedIdddddgZ[ed@dddddddgZ\edFdddddgZ]edGdddddgZ^edAddddgZ_eddddgZ`edddddgZaeddddgZbedddgZced8ddddgZded=ddgZeed>dddgZfed?dddgZged:dddgZhed;ddddgZieddd Zn dd Ze|e jfdd]Zddd\Zdde jfd d^Zd
d[ ZdS ( 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_DEBUGFREEBSDBSDLINUXNETBSDOPENBSDMACOSOSXPOSIXSUNOSWINDOWS
CONN_CLOSECONN_CLOSE_WAIT CONN_CLOSINGCONN_ESTABLISHEDCONN_FIN_WAIT1CONN_FIN_WAIT2
CONN_LAST_ACK CONN_LISTEN CONN_NONE
CONN_SYN_RECV
CONN_SYN_SENTCONN_TIME_WAITNIC_DUPLEX_FULLNIC_DUPLEX_HALFNIC_DUPLEX_UNKNOWN STATUS_DEADSTATUS_DISK_SLEEP STATUS_IDLE
STATUS_LOCKEDSTATUS_RUNNINGSTATUS_SLEEPINGSTATUS_STOPPEDSTATUS_SUSPENDEDSTATUS_TRACING_STOPSTATUS_WAITINGSTATUS_WAKE_KILL
STATUS_WAKING
STATUS_ZOMBIE
STATUS_PARKEDENCODING
ENCODING_ERRSr pconn pcputimespctxswpgidspiopionice popenfilepthreadpuidssconn scpustatssdiskio sdiskpart
sdiskusagesnetiosnicaddr snicstatssswapsuser conn_tmapdeprecated_method
isfile_strictmemoizeparse_environ_blockpath_exists_strict
usage_percent
supports_ipv6sockfam_to_enumsocktype_to_enum wrap_numbers open_text open_binarycatbcat bytes2humanconn_to_ntupledebughiliteterm_supports_colors print_colorposixntlinuxdarwin)ZfreebsdZ midnightbsdZopenbsdZnetbsd)sunossolarisaixrunningsleepingz
disk-sleepstoppedz tracing-stopzombieZdeadz wake-killZwakingidlelockedZwaitingZ suspendedZparkedZ ESTABLISHEDZSYN_SENTZSYN_RECVZ FIN_WAIT1Z FIN_WAIT2Z TIME_WAITZCLOSEZ
CLOSE_WAITZLAST_ACKZLISTENZCLOSINGNONE c @ s e Zd ZdZdZdZdS ) NicDuplexrk rl r N)__name__
__module__ __qualname__r" r# r$ rq rq A/opt/alt/python38/lib64/python3.8/site-packages/psutil/_common.pyrm s rm c @ s e Zd ZdZdZdS ) BatteryTimers rt N)rn ro rp POWER_TIME_UNKNOWNPOWER_TIME_UNLIMITEDrq rq rq rr ru s ru replacesurrogateescapetotalusedfreepercentsinZsoutZ
read_countZ write_count
read_bytes write_bytesZ read_timeZ
write_timeZdeviceZ
mountpointZfstypeoptsZ
bytes_sentZ
bytes_recvZ packets_sentZ packets_recvZerrinZerroutZdropinZdropoutnameZterminalhoststartedpidfdfamilytypeladdrraddrstatusaddressnetmask broadcastZptpZisupZduplexspeedZmtuflagsZ ctx_switchesZ
interruptsZsoft_interruptsZsyscallsscpufreqcurrentminmaxshwtemplabelhighcriticalsbatteryZsecsleftZ
power_pluggedsfanusersystem
children_userchildren_systempathidZ user_timeZ system_timerealZ effectiveZsavedZioclassvalueZ voluntaryZ involuntaryaddripport)allZtcpZtcp4ZudpZudp4ZinetZinet4Zinet6)Ztcp6Zudp6unixc @ 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 OrderedDictgetattr)selfattrsinfor r rq rq rr _infodict$ s
zError._infodictc C sP | d}|r,dddd | D }nd }ddd t| dd |fD S )
N)r ppidr z(%s), c S s g | ]\}}d ||f qS z%s=%rrq .0kvrq rq rr
3 s z!Error.__str__.. c S s g | ] }|r|qS rq rq )r xrq rq rr r 7 s msg )r joinitemsr r r detailsrq rq rr __str__. s
z
Error.__str__c C s2 | d}ddd | D }d| jj|f S )N)r r r secondsr r c S s g | ]\}}d ||f qS r rq r rq rq rr r < s z"Error.__repr__..z
psutil.%s(%s))r r r __class__rn r rq rq rr __repr__9 s
zError.__repr__N)rn ro rp __doc__r r r rq rq rq rr r s
r c @ s& e Zd ZdZdZdddZdd 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 existsr __init__r r r r r r r rq rq rr r G s
zNoSuchProcess.__init__c C s | j | j| j| jffS Nr r r r r rq rq rr
__reduce__M s zNoSuchProcess.__reduce__)NNrn ro rp r r r rq rq rq rr r @ s
r c @ s& e Zd ZdZdZdddZdd 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 rq rq rr r [ s zZombieProcess.__init__c C s | j | j| j| j| jffS r )r r r r r r rq rq rr r ` s zZombieProcess.__reduce__)NNNr rq rq rq rr r Q s
r c @ s& e Zd ZdZdZdddZdd ZdS ) AccessDeniedz@Exception raised when permission to perform an action is denied.r Nc C s$ t | || _|| _|p d| _d S )Nr r r rq rq rr r i s
zAccessDenied.__init__c C s | j | j| j| jffS r r r rq rq rr r o s zAccessDenied.__reduce__)NNNr rq rq rq rr r d s
r c @ s& e Zd ZdZdZdddZdd 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 rq rq rr r z s
zTimeoutExpired.__init__c C s | j | j| j| jffS r )r r r r r rq rq rr r s zTimeoutExpired.__reduce__)NNr rq rq rq rr 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 rq )r
from_valuerq rq rr
raise_from s r c C sF zt | | d }W n tk
r* Y dS X |dk r>t||}|S dS )z5Calculate percentage usage of 'used' against 'total'.d g N)floatZeroDivisionErrorround)r{ rz Zround_retrq rq rr rN s
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 tk
rz z| | } |< W n, tk
rp } zt|d W 5 d }~X Y nX | Y S X d S r ) frozensetsortedr KeyError Exceptionr )argskwargskeyr errcachefunrq rr wrapper s
zmemoize..wrapperc s dS )z Clear cache.N)clearrq )r rq rr cache_clear s z memoize..cache_clear) functoolswrapsr )r r r rq r rr rK s 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 tk
r^ z | W Y S tk
rX } zt|d W 5 d }~X Y nX Y nr tk
r z | }W n, tk
r } zt|d W 5 d }~X Y nX z|| j < W n tk
r Y nX Y nX |S r )_cacheAttributeErrorr r r )r r r r rq rr r s" z'memoize_when_activated..wrapperc S s
i | _ dS )zsActivate cache. Expects a Process instance. Cache will be
stored as a "_cache" instance attribute.
N)r procrq rq rr cache_activate s z.memoize_when_activated..cache_activatec S s" z| ` W n tk
r Y nX dS )zDeactivate and clear cache.N)r r r rq rq rr cache_deactivate s z0memoize_when_activated..cache_deactivate)r r r r )r r r r rq r rr memoize_when_activated s r c
C s\ zt | }W n< tk
rJ } z |jtjtjfkr4 W Y dS d}~X Y nX t|jS dS )zSame as os.path.isfile() but does not swallow EACCES / EPERM
exceptions, see:
http://mail.python.org/pipermail/python-dev/2012-June/120787.html.
FN)osstatOSErrorerrnoEPERMEACCESS_ISREGst_mode)r str rq rq rr rJ s c
C sT zt | W n< tk
rJ } z |jtjtjfkr4 W Y dS d}~X Y nX dS dS )zSame as os.path.exists() but does not swallow EACCES / EPERM
exceptions. See:
http://mail.python.org/pipermail/python-dev/2012-June/120787.html.
FNT)r r r r r r )r r rq rq rr rM - s c C sd t jrtdkrdS z4t tt j} t| | d W 5 Q R X W dS t jk
r^ Y dS X dS )z2Return True if IPv6 is supported on this platform.NF)z::1r T)sockethas_ipv6r r
contextlibclosingbinderror)sockrq rq rr rO < s 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 =rl )r findupper)datar posZWINDOWS_Znext_posZ equal_posr r rq rq rr rL J s
c C s6 t dkr | S z t| W S tk
r0 | Y S X dS )zConvert a numeric socket family value to an IntEnum member.
If it's not a known member, return the numeric value itself.
N)enumr
AddressFamily
ValueErrornumrq rq rr rP f s c C s6 t dkr | S z t| W S tk
r0 | Y S X 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 rq rq rr rQ s s c C s |t jtfkr&|rt| }|r&t| }|t jkrJ|ttfkrJ||t}nt}t|}t|}|dkrxt | |||||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 famtype_r r r Z
status_mapr rq rq rr rX s c s fdd}|S )zA 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 kr | _t| fdd}|S )Nz8%s() is deprecated and will be removed; use %s() insteadc s t j tdd t| ||S )Nrk )category
stacklevel)warningswarnDeprecationWarningr )r r r )r replacementrq rr inner s z/deprecated_method..outer..inner)rn r r r )r r r )r rr outer s
z deprecated_method..outerrq )r r rq r rr rI s 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 ) threadingLocklockr reminders
reminder_keysr rq rq rr r s
z_WrapNumbers.__init__c C sX || j kst|| jks t|| jks*t|| j |< tt| j|< tt| j|< d S r )r AssertionErrorr r r defaultdictintset)r
input_dictr rq rq rr _add_dict s
z_WrapNumbers._add_dictc C s\ | j | }t| t| }|D ]0}| j| | D ]}| j| |= q8| j| |= q&dS )zIn 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_keyremkeyrq rq rr _remove_dead_reminders s
z#_WrapNumbers._remove_dead_remindersc
C s || j kr| || |S | || | j | }i }|D ]}|| }z || }W n tk
rp |||< Y q8Y nX g }tt|D ]f} || }
|| } || f} |
| k r| j| | | 7 < | j| | | | |
| j| | qt
|||< q8|| j |< |S )zlCache dict and sum numbers which overflow and wrap.
Return an updated copy of `input_dict`.
) r r% r) r rangelenr r addappendtuple)
r r$ r r' Znew_dictr Z input_tupleZ old_tuplebitsiZ input_value old_valuer( rq rq rr run s2
z_WrapNumbers.runNc C sh | j X |dkr0| j | j | j n*| j|d | j|d | j|d W 5 Q R X dS )z>Clear the internal cache, optionally only for function 'name'.N)r r r r r pop)r r rq rq rr r s
z_WrapNumbers.cache_clearc
C s. | j | j| j| jfW 5 Q R S Q R X dS )z5Return internal cache dicts as a tuple of 3 elements.N)r r r r r rq rq rr
cache_info s z_WrapNumbers.cache_info)N)
rn ro rp r r r% r) r2 r r4 rq rq rq rr r s '
r c
C s* t j t | |W 5 Q R S Q R X dS )zGiven 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 rq rq rr rR s i c C s t | dtdS )Nrb buffering)openFILE_READ_BUFFER_SIZE)fnamerq rq rr rT s c C s` t st| tdS t| tttd}z
t|_W n0 tk
r> Y n tk
rZ | Y nX |S )zOn 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 encodingerrors) PY3r9 r: r3 r4 _CHUNK_SIZEr r close)r; Zfobjrq rq rr rS " s
c
C sz |t kr.|| }| W 5 Q R S Q R X nHz*|| }| W 5 Q R W S Q R X W n ttfk
rt | Y S X dS )zRead 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)_DEFAULTreadIOErrorr )r; fallback_openfrq rq rr rU @ s
c C s t | |tdS )z,Same as above but opens file in binary mode.)rD rE )rU rT )r; rD rq rq rr rV Q s %(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 )zUsed by various scripts. See: http://goo.gl/zeJZl.
>>> bytes2human(10000)
'9.8K'
>>> bytes2human(100001221)
'95.4M'
) BKMGTPEZYrl N
r )symbolr ) enumeratereversedabsr localsdict)nformatsymbolsprefixr0 srR r rq rq rr rW V s c C s t jd jS )z+Return updated psutil.PROCFS_PATH constant.r )sysmodulesZ PROCFS_PATHrq rq rq rr get_procfs_pathi s r_ c C s | j ttdS )N)r< r= )decoder3 r4 r\ rq rq rr r` p s r` c C s | S r rq ra rq rq rr r` u s c C s` t jdkrdS z2dd l}| s$t| |ddks>tW n tk
rV Y dS X dS d S )Nr^ Tr colorsF)r r cursesisattyr Z setuptermZtigetnumr )filerc rq rq rr r[ ~ s
Fc C s t s
| S g }tddddddddd d
}d |d < z || }W n( tk
rd td
t| Y nX || |r~|d dd|| f S )z*Return an highlighted version of 'string'.Z34Z33Z30Z32Z37Z36Z91Z35Z93) bluebrownZdarkgreygreenZgreyZ lightblueredvioletyellowZ29Nz#invalid color %r; choose between %s1z [%sm%s[0m;)r[ rW r r
listr& r- r )r\ colorboldattrrb rq rq rr rZ s2
c C s t st| |d ntr.tt| |||d nddl}d}|jjj}|jjj}t ddddd}||d< z || }W n, t
k
r t d |t |
f Y nX |r|dkr|d
7 }|tjkrd nd } |j|_|| }
||
| zt| |d W 5 ||
| X dS )
z$Print a colorized version of string.re r N rk )rh ri rg rk z#invalid color %r; choose between %r ii)r[ printr rZ ctypeswindllZKernel32 GetStdHandleSetConsoleTextAttributerW r r
rn r& r] stderrZc_ulongrestype) r\ ro rp re rx Z
DEFAULT_COLORrz r{ rb Z handle_idhandlerq rq rr r\ s8
c C sn t rjddl}|| j\}}}}}t| trRt| ttt frJd| } 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]> %srr )
r inspect getframeinfo currentframef_back
isinstancer r rC EnvironmentErrorrw r] r| )r r r; lineno__lines_indexrq rq rr rY s
)N)N)rG )NF)r
__future__r r r r r r r r r r] r r r r r r r ImportErrorr version_infor> r boolgetenvr objectrA __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$ IntEnumrm globalsupdate __members__rv rw ru 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__rW 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_ r` stdoutr[ rZ r\ rY rq rq rq rr sD
&
#
-G
W '