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/gZUed0d,d-d1d2gZVed3d4d5d6d7d8gZWed9d:d;gZXeXZYed<d=d:d>d?gZZed@dAdB[eZj\ Z]dCdD Z^dEdF Z_dGdH Z`dIdJ ZadKdL ZbdMdN ZcdOdP ZdejeZee jfZfdedRdSZgejhZhejiZidfdUdVZjdWdX ZkdYdZ Zld[d\ Zmd]d^ Znd_d` Zodadb ZpG dcdd ddeqZrdS )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
) ppidrssvms create_timenice num_threadsstatusttynruideuidgidegid scputimesusersystemZidleZiowait pcputimes
children_userchildren_systemsvmemtotalZ availablepercentusedfreepmemr& r'
pmmap_groupedpathZ anonymouslocked pmmap_extz addr perms c C sF t dt } t dt }}| | }t|| dd}t| ||||S )z Report virtual memory metrics.
SC_PHYS_PAGESSC_AVPHYS_PAGESr Zround_)ossysconf PAGE_SIZEr r7 )r8 r; Zavailr: r9 rH B/opt/alt/python38/lib64/python3.8/site-packages/psutil/_pssunos.pyvirtual_memory{ s
rJ c
C s
t \} }tjddtjd ddgtjd}| \}}trL| t
j j }|j
dkrdtd|j
| d d
d }|std 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:%sPATHZswapz-l)stdoutr z 'swap -l' failed (retcode=%s)
r Nz no swap device(s) configuredr r i rD )cextZswap_mem
subprocessPopenrE environPIPE communicater decodesysrL encoding
returncode RuntimeErrorstripsplitintr r ZsswaprG )
ZsinZsoutprL stderrlinesr8 r; linetfr: 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.0xrH rH rI
<listcomp> s z cpu_times.<locals>.<listcomp>)rN
per_cpu_timesr1 zipretrH 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 dW 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 sdiskpartappend) allretlistZ
partitions partitionZdeviceZ
mountpointZfstypeZoptserrZmaxfileZmaxpathZntuplerH rH rI rs s(
rs c
C s t j }|dkr |dd | |krFtd| ddd |D f t j| \}}t|}t }|D ]}|\}} }
} } }
}| |krqh|
|krqh| t t
fkr| rt j | } | rt j | } t |
}
t
| } t|
}
|dkrt || |
| | |
|}nt || |
| | |
}|| qht|S )zReturn 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_tmapcopypoprn joinrN net_connectionssetr r
addr TCP_STATUSESr r Zsconnpconnaddlist)kind_pidZcmapZfamiliestypesrawlistrk itemfdZfamZtype_ZladdrZraddrr+ pidntrH rH rI r s:
r c C sR t } | D ]<\}}|\}}}}ttdr8t|}t||||| |< q| S )z)Get NIC stats (isup, duplex, speed, mtu). NicDuplex)rN net_if_statsitemshasattrr 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 )zCall 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| js@t| j| jnt| j| j| jY n\ tk
rv t | j| jY n< t
k
r | jdkrdt krt | j| jn Y nX d S Nr ) r r r r r _namer _ppidr r ru r )selfargskwargsfunrH rI wrapper\ s
z wrap_exceptions.<locals>.wrapper) functoolswraps)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@dAZ%e$d@dBZ&e dCdD Z'e dEdF Z(e dGdH Z)e dMdJdKZ*dIS )NProcessz1Wrapper 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| jS r )rN Zproc_name_and_argsr r r rH rH rI r s zProcess._proc_name_and_argsc C s@ | j dkr,tjd| j| j f s,t| j t| j | j}|S )Nr z %s/%s/psinfo)r rE r> existsr r rN Zproc_basic_info)r rk rH rH rI r s
zProcess._proc_basic_infoc C s t | j| jS 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 dS )Nr rA )r rZ r rH rH rI r s zProcess.cmdlinec C s t | j| jS r )rN Z proc_environr r r rH rH rI rQ s zProcess.environc C s | td S )Nr( r
proc_info_mapr 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 | jt| 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 effectivesaved_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| jS 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 td|| 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 }ztd|| jf W S tk
rF td|| 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|dS )Nr+ ?)r r
PROC_STATUSESget)r coderH rH rI r+ , s zProcess.statusc
C s | j }g }td|| jf }d}|D ]}t|}zt| j||\}}W nT tk
r } z6|jtj krtt
stW Y q&|jtj krd}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_threadEnvironmentErrorr r r ENOENTr Zpthreadrv r )
r r rk Ztidsr tidutimeZstimerz r rH rH rI threads2 s0 zProcess.threadsc C s g }d}| j }d|| jf }td|| 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 \}}|jdkrd| krht| j| j d| krt
| j| j t d ||f | d
d d }t
|D ]v\}}| }|d
r| dd d } ||d }
|
dkrtj}
n|
dkrtj}
nd}
dtj|
| dtjfV qd S )z<Get UNIX sockets used by process by parsing 'pfiles' output.z pfiles %sT)shellrL r] c S s g | ]}| tjjqS 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 enumeratelstrip
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_socketsinetc C sP t || jd}|s(td| j| jf |dkrL|dd | | jD |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 ]}|\}} }
} } }
}||| }| dszt
d|| j| f } W nF tk
r } z(|jtj krd|| j| f } d}n W 5 d }~X Y nX | ||
| | |
|f qn|r |
|S )Nc S s0 dt | dd dt |dd df S )Nz%s-%sr L)hexrY )startendrH 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 td| j| jf S )Nz%s/%s/fd)lenrE 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|| jS 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_LINKmaxsizer 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
&
!
%