Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
duality-group / ray python
Repository URL to install this package:
|
Version:
2.0.0rc1 ▾
|
o
õbc ã @ s8 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! g d¢Z"e #¡ Z$ej%Z%ej&dkZ'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)g d*¢ZUed+g d,¢ZVed-g d.¢ZWed/d0d1gZXeXZYed2g d3¢ZZed4d5d6 [eZj\¡ Z]d7d8 Z^d9d: Z_d;d< Z`d=d> Zad?d@ ZbdAdB ZcdCdD ZdejeZee jfZfdYdFdGZgejhZhejiZidZdIdJZjdKdL ZkdMdN ZldOdP ZmdQdR ZndSdT ZodUdV ZpG dWdX dXeqZrdS )[z'Sun OS Solaris platform implementation.é N)Ú
namedtuple)ÚAF_INETé )Ú_common)Ú_psposix)Ú
_psutil_posix)Ú
_psutil_sunos)ÚAF_INET6)Ú AccessDenied)Ú
NoSuchProcess)Ú
ZombieProcess)Údebug)Úget_procfs_path)Ú
isfile_strict)Úmemoize_when_activated)Úsockfam_to_enum)Úsocktype_to_enum)Ú
usage_percent)ÚPY3)ÚFileNotFoundError)ÚPermissionError)ÚProcessLookupError)Úb)Ú CONN_IDLEÚ
CONN_BOUNDZ PROCFS_PATHl ZIDLEZBOUNDé é é é é é é é é
é ) ÚppidÚrssÚvmsÚ create_timeÚniceÚ num_threadsÚstatusÚttynrÚuidÚeuidÚgidÚegidÚ scputimes)ÚuserÚsystemÚidleZiowaitÚ pcputimes)r2 r3 Ú
children_userÚchildren_systemÚsvmem)ÚtotalÚ availableÚpercentÚusedÚfreeÚpmemr& r' Ú
pmmap_grouped)Úpathr& Z 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_N)ÚosÚsysconfÚ PAGE_SIZEr r8 )r9 r= Zavailr< r; © rJ ú6/tmp/pip-target-wec6zj2z/lib/python/psutil/_pssunos.pyÚvirtual_memory{ s
rL c
C s
t ¡ \} }tjddtjd ddgtjd}| ¡ \}}tr&| t
j j ¡}|j
dkr2td|j
| ¡ d ¡d
d
}|sCtd d }}|D ]"}| ¡ }|d
d
\} }
|tt| d 7 }|tt|
d 7 }qI|| } 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 rF )ÚcextZswap_memÚ
subprocessÚPopenrG ÚenvironÚPIPEÚ communicater ÚdecodeÚsysrN ÚencodingÚ
returncodeÚ RuntimeErrorÚstripÚsplitÚintr r ZsswaprI )
ÚsinZsoutÚprN ÚstderrÚlinesr9 r= ÚlineÚtÚfr< r; rJ rJ rK Ú swap_memory s6 ÿÿþ
ÿre c C s t ¡ } tdd t| D S )z-Return system-wide CPU times as a named tuplec S ó g | ]}t |qS rJ )Úsum©Ú.0ÚxrJ rJ rK Ú
<listcomp>¯ ó z cpu_times.<locals>.<listcomp>N)rP Ú
per_cpu_timesr1 Úzip©ÚretrJ rJ rK Ú cpu_times¬ s rq c C s t ¡ } dd | D S )z5Return system per-CPU times as a list of named tuplesc S s g | ]}t | qS rJ )r1 rh rJ rJ rK rk µ rl z!per_cpu_times.<locals>.<listcomp>N)rP rm ro rJ rJ rK rm ² s rm c C s" zt d¡W S ty Y dS w )z0Return the number of logical CPUs in the system.ÚSC_NPROCESSORS_ONLNN)rG rH Ú
ValueErrorrJ rJ rJ rK Úcpu_count_logical¸ s
þrt c C ó t ¡ S )z-Return the number of CPU cores in the system.N)rP Úcpu_count_coresrJ rJ rJ rK rv Á ó rv c C s$ t ¡ \} }}}d}t | |||¡S )z*Return various CPU stats as a named tuple.r N)rP Ú cpu_statsr Z scpustats)Z ctx_switchesZ
interruptsZsyscallsZtrapsZsoft_interruptsrJ rJ rK rx Æ s
ÿrx Fc C s¤ g }t ¡ }|D ]G}|\}}}}|dkrd}| s<z t|js W qW n ty; } ztd||f W Y d}~qd}~ww d } }
t ||||| |
¡} | | ¡ q|S )z Return system disk partitions.ÚnoneÚ zskipping %r: %sN) rP Údisk_partitionsÚ
disk_usager9 ÚOSErrorr
r Z sdiskpartÚappend) ÚallÚretlistZ
partitionsÚ partitionZdeviceZ
mountpointZfstypeÚoptsÚerrZmaxfileZmaxpathZntuplerJ rJ rK r{ × s,
ÿ ý ÿ r{ éÿÿÿÿc
C s t j ¡ }|dkr| dd¡ | |vr#td| d dd |D ¡f t j| \}}t |¡}t }|D ]T}|\}} }
} } }
}| |vrDq4|
|vrIq4| t t
fv r]| rVt j | } | r]t j | } t |
}
t
| } t|
}
|dkryt || |
| | |
|¡}n
t || |
| | |
¡}| |¡ q4t|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 rf rJ )Úreprrh rJ rJ rK rk rl z#net_connections.<locals>.<listcomp>N)r Z conn_tmapÚcopyÚpoprs ÚjoinrP Únet_connectionsÚsetr r ÚaddrÚ TCP_STATUSESr r ZsconnÚpconnÚaddÚlist)ÚkindÚ_pidZcmapZfamiliesÚtypesÚrawlistrp ÚitemÚfdÚfamÚtype_ÚladdrÚraddrr+ ÚpidÚntrJ rJ rK r ü s:
ÿ
r c C sR t ¡ } | ¡ D ] \}}|\}}}}ttdr t |¡}t ||||¡| |< q| S )z)Get NIC stats (isup, duplex, speed, mtu).Ú NicDuplexN)rP Ú net_if_statsÚitemsÚhasattrr r Z snicstats)rp Únamer ZisupZduplexÚspeedZmturJ rJ rK r ! s
r c C ru )z:The system boot time expressed in seconds since the epoch.N)rP Ú boot_timerJ rJ rJ rK r£ 1 rw 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Ú localhostN)rP Úusersr Zsuserr~ ) r r r¤ r r2 ÚttyÚhostnameZtstampZ user_processr r rJ rJ rK 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 rJ )Úisdigitr] rh rJ rJ rK rk P s zpids.<locals>.<listcomp>N)rG Úlistdirr r rJ rJ rJ rK ÚpidsN ó rª c C s
t | ¡S )z&Check for the existence of a unix pid.N)r Ú
pid_exists)r rJ rJ rK 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 | g|¢R i |¤W S t tfy* t| js!t| j| jt| j| j| j ty7 t | j| j t
yP | jdkrOdt v rNt | j| j w ©Nr ) r r r¬ r r Ú_namer Ú_ppidr r
r} rª )ÚselfÚargsÚkwargs©ÚfunrJ rK Úwrapper\ s
úz wrap_exceptions.<locals>.wrapperN)Ú functoolsÚwraps)r´ rµ rJ r³ rK Úwrap_exceptionsX s r¸ c @ s¬ e Zd ZdZg d¢Zdd Zdd Zdd Zd d
Ze e
d d Z e e
d
d Z e e
dd Z
e dd Ze dd Ze 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. Z e d/d0 Z e Z e d1d2 Z e d3d4 Z e d5d6 Z!d7d8 Z"e dHd:d;Z#e$d<d=Z%e$d<d>Z&e d?d@ Z'e dAdB Z(e dCdD Z)e dIdFdGZ*dES )JÚ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 rJ rJ rK Ú__init__y s zProcess.__init__c C s t d| j| jf ¡ dS )z+Raise NSP if the process disappeared on us.ú%s/%sN)rG Ústatrº r ©r° rJ rJ rK Ú
_assert_alive s zProcess._assert_alivec C ó( | j | ¡ | j | ¡ | j | ¡ d S r¼ )Ú_proc_name_and_argsZcache_activateÚ_proc_basic_infoÚ
_proc_credrÀ rJ rJ rK Ú
oneshot_enter
ó zProcess.oneshot_enterc C r r¼ )rà Zcache_deactivaterÄ rÅ rÀ rJ rJ rK Ú oneshot_exit rÇ zProcess.oneshot_exitc C ó t | j| j¡S r¼ )rP Zproc_name_and_argsr rº rÀ rJ rJ rK rà ó zProcess._proc_name_and_argsc C sT | j dkrtj d| j| j f ¡st| j t | j | j¡}t|tt ks(J |S )Nr z %s/%s/psinfo)
r rG r@ Úexistsrº r
rP Zproc_basic_infoÚlenÚ
proc_info_map)r° rp rJ rJ rK rÄ s
ÿ
zProcess._proc_basic_infoc C rÉ r¼ )rP Z proc_credr rº rÀ rJ rJ rK rÅ rÊ zProcess._proc_credc C s | ¡ d S r )rà rÀ rJ rJ rK r¡ £ s z Process.namec C s8 z t d| j| jf ¡W S ty Y nw | ¡ dS )Nz%s/%s/path/a.outrz )rG Úreadlinkrº r r} ÚcmdlinerÀ rJ rJ rK Úexe¨ s ÿ ÿz Process.exec C s | ¡ d d¡S )Nr rC )rà r\ rÀ rJ rJ rK rÏ µ ó zProcess.cmdlinec C rÉ r¼ )rP Z proc_environr rº rÀ rJ rJ rK rS ¹ ó zProcess.environc C ó | ¡ td S )Nr( ©rÄ rÍ rÀ rJ rJ rK r( ½ rÒ zProcess.create_timec C rÓ )Nr* rÔ rÀ rJ rJ rK r* Á rÒ zProcess.num_threadsc C rÓ )Nr) rÔ rÀ rJ rJ rK Únice_getÅ s zProcess.nice_getc C s& | j dv r t| j | jt | j |¡S )N)r r )r r
r® Ú
cext_posixÚ setpriority)r° ÚvaluerJ rJ rK Únice_setÌ s
zProcess.nice_setc C s | ¡ td | _| jS )Nr% )rÄ rÍ r¯ rÀ rJ rJ rK r% Ö s z Process.ppidc C s^ z | ¡ \}}}}}}W n ty' | ¡ td }| ¡ td }d }Y nw t |||¡S )Nr- r. ©rÅ r
rÄ rÍ r Zpuids)r° ÚrealÚ effectiveÚsavedÚ_rJ rJ rK ÚuidsÛ ó ýz Process.uidsc C s^ z | ¡ \}}}}}}W n ty' | ¡ td }| ¡ td }d }Y nw t |||¡S )Nr/ r0 rÚ )r° rÞ rÛ rÜ rÝ rJ rJ rK Úgidså rà z Process.gidsc
C s\ z
t | j| j¡}W n ty( } z|jtjkr ts d}n W Y d }~nd }~ww tj | S )N)ç râ râ râ )
rP Zproc_cpu_timesr rº r} ÚerrnoÚ EOVERFLOWÚ IS_64_BITr r5 )r° Útimesr rJ rJ rK rq ï s þ÷
zProcess.cpu_timesc C rÉ r¼ )rP Z proc_cpu_numr rº rÀ rJ rJ rK Úcpu_num rÒ zProcess.cpu_numc C sx | j }d}t| ¡ td }|tjkr2dD ]}zt d|| j|f ¡W S t y1 d}Y qw |r:|
¡ d S d S )NFr, )r r r éÿ z
%s/%d/path/%dT) rº r¸ rÄ rÍ rP ZPRNODEVrG rÎ r r rÁ )r° Ú procfs_pathÚ
hit_enoentr¦ rj rJ rJ rK Úterminal s$ ÿ
ÿ þ ÿzProcess.terminalc C sF | j }z t d|| jf ¡W S ty" t d|| jf ¡ Y d S w )Nz%s/%s/path/cwdr¾ )rº rG rÎ r r r¿ )r° ré rJ rJ rK Úcwd s þz Process.cwdc C s2 | ¡ }|td d }|td d }t||S )Nr& i r' )rÄ rÍ r> )r° rp r& r' rJ rJ rK Ú memory_info# s
zProcess.memory_infoc C s | ¡ td }t |d¡S )Nr+ ú?)rÄ rÍ Ú
PROC_STATUSESÚget)r° ÚcoderJ rJ rK r+ , s zProcess.statusc
C sÈ | j }g }t d|| jf ¡}d}|D ]H}t|}z t | j||¡\}}W n) tyN } z |jtj kr;t
s;W Y d }~q|jtj krId}W Y d }~q d }~ww t
|||¡} | | ¡ q|rb| ¡ |S )Nz %s/%d/lwpFT)rº rG r© r r] rP Zquery_process_threadÚEnvironmentErrorrã rä rå ÚENOENTr Zpthreadr~ rÁ )
r° ré rp Ztidsrê ÚtidÚutimeZstimer r rJ rJ rK Úthreads2 s0 ÿ ò zProcess.threadsc C s¤ g }d}| j }d|| jf }t d|| jf ¡D ]1}tj ||¡}tj |¡rIzt |¡}W n ty9 d}Y qw t |rI|
t |t
|¡¡ q|rP| ¡ |S )NFz
%s/%d/pathz%s/%d/fdT)rº r rG r© r@ r ÚislinkrÎ r r r~ r Z popenfiler] rÁ )r° r rê ré Zpathdirr r@ ÚfilerJ rJ rK Ú
open_filesS s& þzProcess.open_filesc c s( d| }t j|dt jt jd}| ¡ \}}tr#dd ||fD \}}|jdkrJd| ¡ v r5t| j| j d| ¡ v rBt
| j| j t d ||f | d
¡d d
}t
|D ]:\}}| ¡ }| d
¡r| dd ¡d } ||d ¡ }
|
dkr|tj}
n
|
dkrtj}
nd}
dtj|
| dtjfV qWd S )z<Get UNIX sockets used by process by parsing 'pfiles' output.z pfiles %sT)ÚshellrN r` c S s g | ] }| tjj¡qS rJ )rV rW rN rX rh rJ rJ rK rk q s ÿz-Process._get_unix_sockets.<locals>.<listcomp>r zpermission deniedzno such processz%r command error
%srO r Nzsockname: AF_UNIXrC Ú SOCK_STREAMÚ
SOCK_DGRAMr rz )rQ rR rT rU r rY Úlowerr
r r® r rZ r\ Ú enumerateÚlstripÚ
startswithr[ Úsocketrû rü ÚAF_UNIXr Ú CONN_NONE) r° r Úcmdr_ rN r` ra Úirb r@ ÚtyperJ rJ rK Ú_get_unix_socketsh s< ÿ
ÿ
õzProcess._get_unix_socketsÚinetc C sP t || jd}|st d| j| jf ¡ |dv r&| dd | | j¡D ¡ |S )N)r r¾ )r r
c S s g | ]}t j| qS rJ )r r )ri ÚconnrJ rJ rK rk s z'Process.connections.<locals>.<listcomp>)r r rG r¿ rº Úextendr )r° r rp rJ rJ rK Ú connections s
ÿzProcess.connectionsZmmapzpath rss anon lockedz addr perms path rss anon lockedc C s dd }| j }g }z t | j|¡}W n ty/ } z|jtjkr*ts*g W Y d }~S d }~ww d}|D ]R}|\}} }
} } }
}||| }| d¡s{z
t
d|| j| f ¡} W n$ tyz } z|jtj krod|| j| f } d}n W Y d }~nd }~ww | ||
| | |
|f¡ q4|r|
¡ |S )Nc S s0 dt | dd
d¡t |dd
d¡f S )Nz%s-%sr ÚL)Úhexr[ )ÚstartÚendrJ rJ rK Útoaddr s ÿz#Process.memory_maps.<locals>.toaddrFú[z
%s/%s/path/%sT)rº rP Zproc_memory_mapsr r} rã rä rå r rG rÎ ró r~ rÁ )r° r ré r r r rê r r ZaddrsizeÚpermr¡ r& ZanonrA rJ rJ rK Ú memory_maps s@ õ
ÿ þ÷ zProcess.memory_mapsc C s t t d| j| jf ¡S )Nz%s/%s/fd)rÌ rG r© rº r rÀ rJ rJ rK Únum_fdsÌ r« zProcess.num_fdsc C s t jt | j| j¡ S r¼ )r ZpctxswrP Zproc_num_ctx_switchesr rº rÀ rJ rJ rK Únum_ctx_switchesÐ s ÿzProcess.num_ctx_switchesNc C s t | j|| j¡S r¼ )r Zwait_pidr r® )r° ÚtimeoutrJ rJ rK ÚwaitÕ rÑ z Process.wait)r r¼ )+Ú__name__Ú
__module__Ú __qualname__Ú__doc__Ú __slots__r½ rÁ rÆ rÈ r¸ r rà rÄ rÅ r¡ rÐ rÏ rS r( r* rÕ rÙ r% rß rá rq rç rë rì rí Zmemory_full_infor+ rö rù r r r Znt_mmap_groupedZ nt_mmap_extr r r r rJ rJ rJ rK r¹ t s
.
r¹ )F)r )sr rã r¶ rG r rQ rW Ú collectionsr r rz r r r rÖ r rP r r
r r r
r r r r r r Z_compatr r r r r Z__extra__all__Z getpagesizerI 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 r5 r8 r> Zpfullmemr? r Ú_fieldsrB rL re rq rm rt rv rx Zdisk_io_countersr| r{ Znet_io_countersZ net_if_addrsr r r£ r¥ rª r¬ r¸ Úobjectr¹ rJ rJ rJ rK Ú<module> sÒ
ù òôÿÿÿ &
!
%