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
õbºy ã @ sÜ d Z ddlZddlZddlZddlZddlm mZ ddl m
Z
ddl m Z ddl m
Z
ddl mZ ddl mZ 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
m Z ddl
m Z ddl m Z ddl m Z ddl m!Z! ddl m"Z" g Z#er¼ej$e
j%ej&e
j'ej(e
j)ej*e
j+ej,e
j-ej.e
j/ej0e
j1iZ2n=erÝej$e
j%ej(e
j)ej*e
j+ej3e
j-ej,e
j-ej&e
j4ej5e
j'iZ2n erùej$e
j%ej(e
j)ej*e
j+ej,e
j-ej&e
j4ej5e
j'iZ2ej6e
j7ej8e
j9ej:e
j;ej<e
j=ej>e
j?ej@e
jAejBe
jCejDe
jEejFe
jGejHe
jIejJe
jKejLe
jMi ZNe O¡ ZPejQZQeRedZSeRedZTeRedZUeRed ZVeWdi d dd dd d d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCdDdEdFdGdHdIdJdKdLZXe dMg dN¢ZYe dOg dP¢ZZe dQg dR¢Z[e[Z\e dSg dT¢Z]e dUdVZ^e dWdXZ_erÉe dYg dZ¢Z`ne dYg d[¢Z`d\d] Zad^d_ Zbd`da ZceSrädbd Zdndcd Zddded_ededf Zfesõerúdgdh Zgndidh Zgdjdk Zher
dldm Zinerdndm ZiddodpZjejkZkejlZlejmZmejnZndqdr Zodsdt Zper5dudv Zqdwdx Zrdydz Zsd{d| Zted}d~ Zudd ZvesMerRdd ZwnejwZwdd Zxd
d Zyejzdd Z{G dd de|Z}dS )z5FreeBSD, OpenBSD and NetBSD platforms implementation.é N)Ú defaultdict)Ú
namedtupleé )Ú_common)Ú_psposix)Ú _psutil_bsd)Ú
_psutil_posix)ÚFREEBSD)ÚNETBSD)ÚOPENBSD)Ú AccessDenied)Ú
NoSuchProcess)Ú
ZombieProcess)Ú conn_tmap)Úconn_to_ntuple)Úmemoize)Úmemoize_when_activated)Ú
usage_percent)ÚFileNotFoundError)ÚPermissionError)ÚProcessLookupError)ÚwhichÚ
per_cpu_timesÚproc_num_threadsÚproc_open_filesÚ proc_num_fdsÚppidÚstatusÚreal_uidé Ú
effective_uidé Ú saved_uidé Úreal_gidé Ú
effective_gidé Ú saved_gidé Úttynré Ú create_timeé Úctx_switches_volé
Úctx_switches_unvolé Ú
read_io_counté Úwrite_io_counté
Ú user_timeé Úsys_timeé Ú ch_user_timeé Ú ch_sys_timeé Úrssé Úvmsé Úmemtexté Úmemdataé Úmemstacké Úcpunumé Únameé Úsvmem) ÚtotalÚ availableÚpercentÚusedÚfreeÚactiveÚinactiveÚbuffersÚcachedÚsharedÚwiredÚ scputimes©ÚuserÚniceÚsystemÚidleÚirqÚpmem)r> r@ ÚtextÚdataÚstackÚ pcputimes)rZ r\ Ú
children_userÚchildren_systemÚ
pmmap_groupedú*path rss, private, ref_count, shadow_countÚ pmmap_extú6addr, perms path rss, private, ref_count, shadow_countÚsdiskio)Ú
read_countÚ write_countÚ
read_bytesÚ write_bytesZ read_timeZ
write_timeZ busy_time)rk rl rm rn c C sØ t ¡ } | \}}}}}}}}trItdd,} | D ]!}
|
d¡r*t|
¡ d d }q|
d¡r9t|
¡ d d }qW d n1 sDw Y || | } || | } t|| |dd}
t|| |
| ||||||| S ) z&System virtual memory as a namedtuple.z
/proc/meminfoÚrbs Buffers:r i s
MemShared:N©Zround_) ÚcextZ virtual_memr
ÚopenÚ
startswithÚintÚsplitr rL )ZmemrM rQ rR rS rW rU rT rV ÚfÚlineZavailrP rO © rx ú4/tmp/pip-target-wec6zj2z/lib/python/psutil/_psbsd.pyÚvirtual_memory³ s$
ü ÿ ÿrz c C s4 t ¡ \} }}}}t|| dd}t | |||||¡S )z@System swap memory as (total, used, free, sin, sout) namedtuple.r rp N)rq Zswap_memr r Zsswap)rM rP rQ ÚsinZsoutrO rx rx ry Ú swap_memoryÇ s r| c C s" t ¡ \} }}}}t| ||||S )z+Return system per-CPU times as a namedtupleN)rq Ú cpu_timesrX rY rx rx ry r} Ó s r} c C s> g } t ¡ D ]}|\}}}}}t|||||}| |¡ q| S )ú'Return system CPU times as a namedtupleN)rq r rX Úappend)ÚretZcpu_trZ r[ r\ r] r^ Úitemrx rx ry r Ú s c C s. t dkr t gS tjrtddt_t gS )r~ r ú&supported only starting from FreeBSD 8TN)Úcpu_count_logicalr} r Ú
__called__ÚNotImplementedErrorrx rx rx ry r ê s
Fc C ó t ¡ S )z0Return the number of logical CPUs in the system.N)rq r rx rx rx ry r ö ó r c C s t dkrdS d S )Nr )r rx rx rx ry Úcpu_count_coresü ó r c C s d} t ¡ }|dur5| d¡}|dkr5|d|d
}t |¡}zt| d¡p)d} W | ¡ n| ¡ w | s>t dkr>dS | S )z-Return the number of CPU cores in the system.Nz </groups>éÿÿÿÿr- zgroup/children/group/cpur ) rq Z cpu_topologyÚrfindÚETÚ
fromstringÚlenÚfindallÚclearr )r ÚsÚindexÚrootrx rx ry r s
c C s¬ t r t ¡ \} }}}}nBtrAt ¡ \} }}}}}}tdd}|D ]}| d¡r0t| ¡ d }q!W d n1 s;w Y n
trNt ¡ \} }}}}}}t
| |||¡S )z*Return various CPU stats as a named tuple.z
/proc/statro s intrr N) r rq Ú cpu_statsr
rr rs rt ru r r Z scpustats) ZctxswZintrsZ
soft_intrsZsyscallsZtrapsZfaultsZforksrv rw rx rx ry r s ÿ
þ ÿÿr c
C sÒ g } t }t|D ]]}z t |¡\}}W n ty Y q w |r\zt| d¡d d¡d }W n
ttfy= d}Y nw zt| d¡d d¡d }W n
ttfy[ d}Y nw | t
|||¡¡ q | S )zªReturn frequency metrics for CPUs. As of Dec 2018 only
CPU 0 appears to be supported by FreeBSD and all other cores
match the frequency of CPU 0.
ú r ú/r N) r Úrangerq Úcpu_freqr
rt ru Ú
IndexErrorÚ
ValueErrorr r Úscpufreq)r Únum_cpusÚcpuÚcurrentZavailable_freqZmin_freqZmax_freqrx rx ry r : s* ÿ ÿ ÿr c C s t t ¡ } t | dd¡gS )Ng )Úfloatrq r r r )Úcurrrx rx ry r R s c C sL g }t ¡ }|D ]}|\}}}}d }} t |||||| ¡}
| |
¡ q|S )zReturn mounted disk partitions as a list of namedtuples.
'all' argument is ignored, see:
https://github.com/giampaolo/psutil/issues/906
N)rq Údisk_partitionsr Z sdiskpartr ) ÚallÚretlistZ
partitionsÚ partitionZdeviceZ
mountpointZfstypeÚoptsZmaxfileZmaxpathÚntuplerx rx ry r¡ \ s ÿ r¡ c C s t ¡ } i }| D ]C}zt |¡}t |¡}t |¡\}}W n ty7 } z
|jtjkr- W Y d}~q d}~ww t t
drBt
|¡}t
||||¡||< q |S )z)Get NIC stats (isup, duplex, speed, mtu).NÚ NicDuplex)
Únet_io_countersÚkeysÚ
cext_posixZ
net_if_mtuZnet_if_is_runningZnet_if_duplex_speedÚOSErrorÚerrnoZENODEVÚhasattrr r§ Z snicstats)Únamesr rJ ZmtuZisupZduplexÚspeedÚerrrx rx ry Ú net_if_statsy s"
ÿþ
r± c
C s t r7g }t D ]-}z t| | ¡}W n ttfy Y qw |D ]}t|}| |¡ | tj | ¡ q q|S | tj
vrLt d| d dd t
D ¡f t
| \}}t
}tr]t d¡}nt ¡ }|D ]#}|\} }
} } }
}}|
|v r| |v rt| |
| | |
|t|}| |¡ qct|S )z System-wide network connections.ú+invalid %r kind argument; choose between %sú, c S ó g | ]}t |qS rx ©Úrepr©Ú.0Úxrx rx ry Ú
<listcomp> ó z#net_connections.<locals>.<listcomp>r N)r ÚpidsÚProcessÚ connectionsr
r Úlistr r Zsconnr r ÚjoinÚsetr
rq Únet_connectionsr Ú TCP_STATUSESÚadd)Úkindr ÚpidZconsÚconnÚfamiliesÚtypesÚrawlistr ÚfdÚfamÚtypeÚladdrÚraddrr Úntrx rx ry r s@
ÿ
ý
ÿ ÿ
r c C sb z t ¡ \} }}W n
ty Y dS w |dk}|r tj}n |dkr&tj}n|d }t | ||¡S )zReturn battery info.Nr r é< )rq Úsensors_batteryr
r ZPOWER_TIME_UNLIMITEDZPOWER_TIME_UNKNOWNZsbattery)rO ZminsleftZ
power_pluggedZsecsleftrx rx ry rÒ · s þrÒ c C sr t t} t }t|D ]+}z t |¡\}}|dkrd}d| }| d t ||||¡¡ W q t y6 Y q w | S )z?Return CPU cores temperatures if available, else an empty dict.r NzCore %sZcoretemp)
r r¿ r r rq Zsensors_cpu_temperaturer r Zshwtempr
)r r r r ÚhighrJ rx rx ry Úsensors_temperaturesÇ s ÿ ÿrÔ c C r )z:The system boot time expressed in seconds since the epoch.N)rq Ú boot_timerx rx rx ry rÕ Þ r rÕ c C sf g } t ¡ }|D ](}|\}}}}}|dkrtsJ d}|dkr qt ||p&d|||¡}| |¡ q| S )z:Return currently connected users as a list of namedtuples.r Nú~)rq Úusersr r Zsuserr ) r£ rÊ r rZ ÚttyÚhostnameZtstamprÆ rÐ rx rx ry r× ã s r× c C s: z t d ¡ W dS ty Y dS ty Y dS w )Nr FT)r½ rJ r
r rx rx rx ry Ú
_pid_0_existsø s û ÿrÚ c C s* t ¡ } trd| vrt r| dd¡ | S )z7Returns a list of PIDs currently running on the system.r N)rq r¼ r rÚ Úinsert)r rx rx ry r¼ s r¼ c C s t | ¡}|s | t v S dS )zReturn True if pid exists.TN)r Ú
pid_existsr¼ )rÆ Úexistsrx rx ry rÜ s
rÜ c C s4 zt | ¡td }|t jkW S ty Y dS w )Nr F)rq Úproc_oneshot_infoÚkinfo_proc_mapÚSZOMBÚ Exception)rÆ Ústrx rx ry Ú is_zombie s ÿrã c s t ¡ fdd}|S )z`Decorator which translates bare OSError exceptions into
NoSuchProcess and AccessDenied.
c s z | g|¢R i |¤W S t y( t| jr!t| j| j| jt| j| j ty5 t| j| j t yN | jdkrMdt
v rLt| j| j w ©Nr ) r rã rÆ r Ú_nameÚ_ppidr
r r r« r¼ )ÚselfÚargsÚkwargs©Úfunrx ry Úwrapper( s
úz wrap_exceptions.<locals>.wrapperN)Ú functoolsÚwraps)rë rì rx rê ry Úwrap_exceptions$ s rï c c sf zdV W dS t tfy% t| jr t| j| j| jt| j| j ty2 t | j| jw )z8Same as above, for routines relying on reading /proc fs.N)
r r rã rÆ r rå ræ r
r r )Úinstrx rx ry Úwrap_exceptions_procfs= s
ÿrñ c @ sÞ e Zd ZdZg d¢Zdd Zdd Zeedd Z d d
Z
d d Z ed
d Z edd Z
edd Zedd Zedd Zedd Zedd Zedd Zed d Zer`ed d Zed!d" ZeZed#d$ Zed%d& Zed'd( Zed)d* Z edLd,d-Z edMd/d0Z ed1d2 Z ed3d4 Z ed5d6 Z!ed7d8 Z"ed9d: Z#e$d;d<Z%e$d;d=Z&d>d? Z'e(rÃed@dA Z)ne'Z)e*rÎedBdC Z+ne'Z+eríedDdE Z,edFdG Z-edHdI Z.edMdJdKZ/d.S d.S )Nr½ z1Wrapper class around underlying C implementation.)rÆ rå ræ Ú_cachec C s || _ d | _d | _d S ©N)rÆ rå ræ )rç rÆ rx rx ry Ú__init__S s
zProcess.__init__c C s t | j¡ dS )z+Raise NSP if the process disappeared on us.N)rq Ú proc_namerÆ ©rç rx rx ry Ú
_assert_aliveX s zProcess._assert_alivec C s$ t | j¡}t|ttksJ |S )z;Retrieves multiple process info in one shot as a raw tuple.N)rq rÞ rÆ r rß ©rç r rx rx ry Úoneshot^ s zProcess.oneshotc C ó | j | ¡ d S ró )rù Zcache_activaterö rx rx ry Ú
oneshot_enterf ó zProcess.oneshot_enterc C rú ró )rù Zcache_deactivaterö rx rx ry Ú oneshot_exiti rü zProcess.oneshot_exitc C s( | ¡ td }|d ur|S t | j¡S )NrJ )rù rß rq rõ rÆ )rç rJ rx rx ry rJ l s z Process.namec C s t r| jdkr dS t | j¡S tr6| jdkrdS t| t d| j ¡W d S 1 s/w Y d S | ¡ }|rDt |d pCdS dS )Nr Ú z /proc/%s/exe)
r rÆ rq Zproc_exer
rñ ÚosÚreadlinkÚcmdliner )rç r rx rx ry Úexeq s
$ÿz Process.exec
C s t r | jdkr g S trJzt | j¡W S tyI } z+|jtjkrDt| jr.t | j| j
| j t | js<t
| j| j
| j g W Y d }~S d }~ww t | j¡S rä )r rÆ r
rq Z proc_cmdliner« r¬ ÚEINVALrã r rå ræ rÜ r
)rç r° rx rx ry r s
õ
zProcess.cmdlinec C ó t | j¡S ró )rq Z proc_environrÆ rö rx rx ry Úenviron£ ó zProcess.environc C s8 | ¡ td }t ¡ }z|| W S ty Y d S w )Nr* )rù rß r Zget_terminal_mapÚKeyError)rç Ztty_nrZtmaprx rx ry Úterminal§ s
ÿzProcess.terminalc C s | ¡ td | _| jS )Nr )rù rß ræ rö rx rx ry r ° s z Process.ppidc C ó. | ¡ }t |td |td |td ¡S )Nr r r" )rù r Zpuidsrß ©rç Zrawtuplerx rx ry Úuidsµ ó
ýz Process.uidsc C r )Nr$ r& r( )rù r Zpgidsrß r
rx rx ry Úgids½ r z Process.gidsc C s8 | ¡ }t |td |td |td |td ¡S )Nr6 r8 r: r< )rù r rc rß r
rx rx ry r} Å s
üzProcess.cpu_timesc C ó | ¡ td S )NrH ©rù rß rö rx rx ry Úcpu_numÏ ó zProcess.cpu_numc C s@ | ¡ }t|td |td |td |td |td S )Nr> r@ rB rD rF )rù r_ rß r
rx rx ry Ú memory_infoÓ s
ûzProcess.memory_infoc C r )Nr, r rö rx rx ry r, ß r zProcess.create_timec C s t rt | j¡S t| ¡ S ró )ÚHAS_PROC_NUM_THREADSrq r rÆ r Úthreadsrö rx rx ry Ú num_threadsã s zProcess.num_threadsc C s$ | ¡ }t |td |td ¡S )Nr. r0 )rù r Zpctxswrß r
rx rx ry Únum_ctx_switchesë s
þzProcess.num_ctx_switchesc C sH t | j¡}g }|D ]\}}}t |||¡}| |¡ q
tr"| ¡ |S ró )rq Z proc_threadsrÆ r Zpthreadr r r÷ )rç rÊ r£ Ú thread_idÚutimeZstimer¦ rx rx ry r ò s zProcess.threadsÚinetc C s |t vrtd|d dd t D ¡f trXt | \}}g }t | j¡}|D ])}|\}}} }
} } }
|
| jks8J ||v rO| |v rOt||| |
| | t}| |¡ q&|
¡ t |S t | \}}t | j||¡}g }|D ]}|\}}} }
} } t||| |
| | t}| |¡ qjt
r|
¡ |S )Nr² r³ c S r´ rx rµ r· rx rx ry rº r» z'Process.connections.<locals>.<listcomp>)r r rÀ r
rq r rÆ r rà r r÷ r¿ Zproc_connectionsr )rç rÅ rÈ rÉ r rÊ r rË rÌ rÍ rÎ rÏ r rÆ rÐ rx rx ry r¾ þ s> ÿ ÿ
ÿ zProcess.connectionsNc C s t | j|| j¡S ró )r Zwait_pidrÆ rå )rç Útimeoutrx rx ry Úwait r z Process.waitc C r ró )rª Ú getpriorityrÆ rö rx rx ry Únice_get$ r zProcess.nice_getc C s t | j|¡S ró )rª Ú setpriorityrÆ )rç Úvaluerx rx ry Únice_set( s zProcess.nice_setc C s | ¡ td }t |d¡S )Nr ú?)rù rß Ú
PROC_STATUSESÚget)rç Úcoderx rx ry r , s zProcess.statusc C s( | ¡ }t |td |td dd¡S )Nr2 r4 r )rù r Zpiorß r
rx rx ry Ú io_counters2 s
üzProcess.io_countersc C s< t r | jdkr dS ts
trt | j¡pdS ttrdd)z)Return process current working directory.r Nr rþ )r rÆ r
ÚHAS_PROC_OPEN_FILESrq Zproc_cwdr
r rö rx rx ry Úcwd; s ÿÿþz Process.cwdZmmaprg ri c C s t ró )r
rö rx rx ry Ú_not_implementedP s zProcess._not_implementedc C s t | j¡}dd |D S )z8Return files opened by process as a list of namedtuples.c S s g | ]
\}}t ||¡qS rx )r Z popenfile)r¸ ÚpathrË rx rx ry rº Z s z&Process.open_files.<locals>.<listcomp>N)rq r rÆ )rç rÊ rx rx ry Ú
open_filesV s zProcess.open_filesc C s t | j¡}tr | ¡ |S )z=Return the number of file descriptors opened by this process.N)rq r rÆ r
r÷ rø rx rx ry Únum_fdsa s zProcess.num_fdsc C r ró )rq Zproc_cpu_affinity_getrÆ rö rx rx ry Úcpu_affinity_geto r zProcess.cpu_affinity_getc
C s t ttt }|D ]}||vrtd||f q z
t | j|¡ W d S tyK } z|j t j
t j fv rF|D ]}||vrEtd||f q7 d }~ww )Nz#invalid CPU #%i (choose between %s)) Útupler r r r rq Zproc_cpu_affinity_setrÆ r« r¬ r ZEDEADLK)rç ZcpusZallcpusr r° rx rx ry Úcpu_affinity_sets s, ÿÿÿÿÿõzProcess.cpu_affinity_setc C r ró )rq Zproc_memory_mapsrÆ rö rx rx ry Ú memory_maps r zProcess.memory_mapsc C sL |d u r t | j|¡S t|dkrtdt| |\}}t | j|||¡S )Nr z4second argument must be a (soft, hard) tuple, got %s)rq Zproc_getrlimitrÆ r r r¶ Zproc_setrlimit)rç ÚresourceZlimitsZsoftÚhardrx rx ry Úrlimit s ÿÿzProcess.rlimit)r ró )0Ú__name__Ú
__module__Ú __qualname__Ú__doc__Ú __slots__rô r÷ rï r rù rû rý rJ r r r r r r r
r} r r r Zmemory_full_infor, r r r r¾ r r r r r% r' r Znt_mmap_groupedZ nt_mmap_extr( r& r* ÚHAS_PROC_NUM_FDSr+ r, r. r/ r2 rx rx rx ry r½ N s¢
!
ÿÿ
Ür½ rx )F)~r6 Ú
contextlibr¬ rí rÿ Úxml.etree.ElementTreeÚetreeÚ ElementTreer Ú collectionsr r rþ r r r rq r rª r r
r r r
r r r r r r Z_compatr r r r Z__extra__all__ZSIDLZ STATUS_IDLEZSRUNZSTATUS_RUNNINGZSSLEEPZSTATUS_SLEEPINGZSSTOPZSTATUS_STOPPEDrà Z
STATUS_ZOMBIEZSWAITZSTATUS_WAITINGZSLOCKZ
STATUS_LOCKEDr" ZSDEADZ
STATUS_WAKINGZSONPROCZTCPS_ESTABLISHEDZCONN_ESTABLISHEDZ
TCPS_SYN_SENTZ
CONN_SYN_SENTZTCPS_SYN_RECEIVEDZ
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_NONEZ CONN_NONErà Z getpagesizeZPAGESIZEZAF_LINKr ZHAS_PER_CPU_TIMESr r& r8 Údictrß rL rX r_ Zpfullmemrc rf rh rj rz r| r} r r r r r r r¡ Ú
disk_usageZdisk_io_countersr¨ Z net_if_addrsr± r rÒ rÔ rÕ r× rÚ r¼ rÜ rã rï Úcontextmanagerrñ Úobjectr½ rx rx rx ry Ú<module> sn ù íú
ô
ÿþýüûúùø ÷
ö õ ô
óòñðïîíìëêéèç#ÿÿÿÿÿ
(