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
õbxH ã @ sÎ d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m
Z
ddl m Z ddl m Z
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 ddlmZ ddlm Z ddlm Z ddlm Z dgZ e e
dZ!e e
dZ"e e
dZ#e $¡ Z%ej&Z&e
j'e
j(e
j)e
j*e
j+e
j,e
j-e
j,e
j.e
j/iZ0e
j1e
j2e
j3e
j4e
j5e
j6e
j7e
j8e
j9e
j:e
j;e
j<e
j=e
j>e
j?e
j@e
jAe
jBe
jCe
jDe
jEe
jFe
jGe
jHi ZIeJdddd d d d d d!ZKed"d#d$gZLeLZMed%g d&¢ZNed'g d(¢ZOd)d* ZPd+d, ZQd-d. ZRd/d0 ZSd1d2 ZTd3d4 ZUd5d6 ZVe
jWZWe jXZXdKd8d9ZYejZZZe"r@e
j[Z[dLd;d<Z\d=d> Z]d?d@ Z^dAdB Z_dCdD Z`dEdF ZadGdH ZbG dIdJ dJecZddS )Mz AIX platform implementation.é N)Ú
namedtupleé )Ú_common)Ú_psposix)Ú _psutil_aix)Ú
_psutil_posix)ÚNIC_DUPLEX_FULL)ÚNIC_DUPLEX_HALF)ÚNIC_DUPLEX_UNKNOWN)Ú AccessDenied)Ú
NoSuchProcess)Ú
ZombieProcess)Úconn_to_ntuple)Úget_procfs_path)Úmemoize_when_activated)Ú
usage_percent)ÚPY3)ÚFileNotFoundError)ÚPermissionError)ÚProcessLookupErrorZ PROCFS_PATHÚ proc_threadsÚnet_io_countersÚproc_io_countersé é é é é é )ÚppidÚrssÚvmsÚ create_timeÚniceÚ num_threadsÚstatusÚttynrÚpmemr r! Ú scputimes)ÚuserÚsystemÚidleZiowaitÚsvmem)ÚtotalÚ availableÚpercentÚusedÚfreec C s4 t ¡ \} }}}}t| | | dd}t| ||||S )Nr ©Zround_)ÚcextZ virtual_memr r, )r- Zavailr1 ÚpinnedZinuser/ © r5 ú4/tmp/pip-target-wec6zj2z/lib/python/psutil/_psaix.pyÚvirtual_memoryj s r7 c C s: t ¡ \} }}}| | }t|| dd}t | |||||¡S )z=Swap system memory as a (total, used, free, sin, sout) tuple.r r2 N)r3 Zswap_memr r Zsswap)r- r1 ÚsinZsoutr0 r/ r5 r5 r6 Ú swap_memoryp s r9 c C s t ¡ } tdd t| D S )z-Return system-wide CPU times as a named tuplec S ó g | ]}t |qS r5 )Úsum©Ú.0Úxr5 r5 r6 Ú
<listcomp> ó z cpu_times.<locals>.<listcomp>N)r3 Ú
per_cpu_timesr( Úzip©Úretr5 r5 r6 Ú cpu_times} s rE c C s t ¡ } dd | D S )z5Return system per-CPU times as a list of named tuplesc S s g | ]}t | qS r5 )r( r< r5 r5 r6 r? r@ z!per_cpu_times.<locals>.<listcomp>N)r3 rA rC r5 r5 r6 rA s rA c C s" zt d¡W S ty Y dS w )z0Return the number of logical CPUs in the system.ÚSC_NPROCESSORS_ONLNN)ÚosÚsysconfÚ
ValueErrorr5 r5 r5 r6 Úcpu_count_logical s
þrJ c C sr d} t j| dt jt jd}| ¡ \}}tr dd ||fD \}}|jdkr-td| |f | ¡ ¡ }t |p8d S )Nzlsdev -Cc processorT)ÚshellÚstdoutÚstderrc S ó g | ] }| tjj¡qS r5 ©ÚdecodeÚsysrL Úencodingr< r5 r5 r6 r? ó ÿz#cpu_count_cores.<locals>.<listcomp>r z%r command error
%s)
Ú
subprocessÚPopenÚPIPEÚ communicater Ú
returncodeÚ RuntimeErrorÚstripÚ
splitlinesÚlen)ÚcmdÚprL rM Z
processorsr5 r5 r6 Úcpu_count_cores s ÿ
ÿ
r_ c C s t ¡ \} }}}t | |||¡S )z*Return various CPU stats as a named tuple.N)r3 Ú cpu_statsr Z scpustats)Z ctx_switchesZ
interruptsZsoft_interruptsZsyscallsr5 r5 r6 r` s ÿr` Fc C sh g }t ¡ }|D ])}|\}}}}|dkrd}| s t|js qd }} t |||||| ¡}
| |
¡ q|S )z Return system disk partitions.ÚnoneÚ N)r3 Údisk_partitionsÚ
disk_usager- r Z sdiskpartÚappend) ÚallÚretlistZ
partitionsÚ partitionZdeviceZ
mountpointZfstypeÚoptsZmaxfileZmaxpathÚntupler5 r5 r6 rc ° s
ÿ rc éÿÿÿÿc C s¬ t j}| |vrtd| d dd |D ¡f t j| \}}t |¡}g }|D ],}|\}} }
} } }
}| |vr7q'|
|vr<q't|| |
| | |
t|dkrJ|ndd}| |¡ q'|S )zReturn socket connections. If pid == -1 return system-wide
connections (as opposed to connections opened by one process only).
z+invalid %r kind argument; choose between %sz, c S r: r5 )Úreprr< r5 r5 r6 r? Ù r@ z#net_connections.<locals>.<listcomp>rk N©Úpid) r Z conn_tmaprI Újoinr3 Únet_connectionsr Ú TCP_STATUSESre )ÚkindÚ_pidZcmapZfamiliesÚtypesÚrawlistrD ÚitemÚfdÚfamÚtype_ÚladdrÚraddrr% rn Úntr5 r5 r6 rp Ò s& ÿ
ÿ rp c C sÜ t td} tdd t D }i }|D ]X}t |¡\}}d}d}tjdd|gtjtjd}| ¡ \} }
t
r@d d | |
fD \} }
|j dkr[t
d
| ¡} | d ur[t| d ¡}| d
¡}| |t¡}t ||||¡||< q|S )z)Get NIC stats (isup, duplex, speed, mtu).)ÚFullZHalfc S s g | ]}|d qS )r r5 r< r5 r5 r6 r? í r@ z net_if_stats.<locals>.<listcomp>rb r z/usr/bin/entstatz-d©rL rM c S rN r5 rO r< r5 r5 r6 r? û rS z"Running: (\d+) Mbps.*?(\w+) DuplexNr r )r r ÚsetÚ net_if_addrsr3 Ú net_if_statsrT rU rV rW r rX ÚreÚsearchÚintÚgroupÚgetr
r Z snicstats) Z
duplex_mapÚnamesrD ÚnameZisupZmtuZduplexÚspeedr^ rL rM Z re_resultr5 r5 r6 r é s6 ÿ ÿ
ÿ
ÿ
r c C s t ¡ S )z:The system boot time expressed in seconds since the epoch.N)r3 Ú boot_timer5 r5 r5 r6 r s 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)r3 Úusersr Zsuserre ) rg ru r rv r) ÚttyÚhostnameZtstampZ user_processrn r| r5 r5 r6 r s r c C s dd t t ¡D S )z7Returns a list of PIDs currently running on the system.c S s g | ]
}| ¡ rt|qS r5 )Úisdigitr r< r5 r5 r6 r? - s zpids.<locals>.<listcomp>N)rG Úlistdirr r5 r5 r5 r6 Úpids+ s r c C s t j t j t t| d¡¡S )z&Check for the existence of a unix pid.ZpsinfoN)rG ÚpathÚexistsro r Ústrrm r5 r5 r6 Ú
pid_exists0 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 sp z | g|¢R i |¤W S t tfy* t| js!t| j| jt| j| j| j ty7 t | j| jw ©N)
r r r rn r Ú_namer
Ú_ppidr r )ÚselfÚargsÚkwargs©Úfunr5 r6 Úwrapper9 s
ÿz wrap_exceptions.<locals>.wrapperN)Ú functoolsÚwraps)r r r5 r r6 Úwrap_exceptions5 s
r¡ c @ st e Zd ZdZg d¢Zdd Zdd Zdd Zee d d
Z
ee d d Z ed
d Z edd Z
edd Zedd Zedd Zedd ZerRedd Zed=d d Zed d Zed d! Zed"d# Zed$d% Zed&d' Zed(d) Zed*d+ Zed,d- Z ed.d/ Z e Z ed0d1 Z d2d3 Z ed4d5 Z!ed6d7 Z"ed>d9d:Z#e$r¸ed;d< Z%d8S d8S )?ÚProcessz1Wrapper class around underlying C implementation.)rn r r Ú _procfs_pathÚ_cachec C s || _ d | _d | _t | _d S r )rn r r r r£ )r rn r5 r5 r6 Ú__init__O s zProcess.__init__c C ó | j | ¡ | j | ¡ d S r )Ú_proc_basic_infoZcache_activateÚ
_proc_cred©r r5 r5 r6 Ú
oneshot_enterU ó zProcess.oneshot_enterc C r¦ r )r§ Zcache_deactivater¨ r© r5 r5 r6 Ú oneshot_exitY r« zProcess.oneshot_exitc C ó t | j| j¡S r )r3 Zproc_basic_inforn r£ r© r5 r5 r6 r§ ] ó zProcess._proc_basic_infoc C r r )r3 Z proc_credrn r£ r© r5 r5 r6 r¨ b r® zProcess._proc_credc C s$ | j dkrdS t | j | j¡ d¡S )Nr Zswapperú )rn r3 Z proc_namer£ Úrstripr© r5 r5 r6 r g s
z Process.namec C sÒ | ¡ }|sdS |d }tjj|v r@tj |¡s%tj tj | ¡ |¡¡}tj |¡r:tj |¡r:t |tj
¡r:|S tj |¡}tj d
d¡D ] }tj tj ||¡¡}tj |¡rft |tj
¡rf| S qHdS )Nrb r ÚPATHú:)ÚcmdlinerG r ÚsepÚisabsÚabspathro ÚcwdÚisfileÚaccessÚX_OKÚbasenameÚenvironÚsplit)r r³ Úexer Z possible_exer5 r5 r6 r¾ n s,
ÿ þ ÿz Process.exec C ó t | j¡S r )r3 Z proc_argsrn r© r5 r5 r6 r³ ó zProcess.cmdlinec C r¿ r )r3 Z proc_environrn r© r5 r5 r6 r¼ rÀ zProcess.environc C ó | ¡ td S )Nr" ©r§ Ú
proc_info_mapr© r5 r5 r6 r" ó zProcess.create_timec C rÁ )Nr$ r r© r5 r5 r6 r$ rÄ zProcess.num_threadsc C sV t | j¡}g }|D ]\}}}t |||¡}| |¡ q
|s)t d| j| jf ¡ |S )Nú%s/%s) r3 r rn r Zpthreadre rG Ústatr£ )r ru rg Ú thread_idÚutimeZstimerj r5 r5 r6 Úthreads s zProcess.threadsÚinetc C s, t || jd}|st d| j| jf ¡ |S )N)rs rÅ )rp rn rG rÆ r£ )r rr rD r5 r5 r6 Ú connections« s zProcess.connectionsc C r¿ r )Ú
cext_posixÚ getpriorityrn r© r5 r5 r6 Únice_get¸ rÀ zProcess.nice_getc C s t | j|¡S r )rÌ Ú setpriorityrn )r Úvaluer5 r5 r6 Únice_set¼ s zProcess.nice_setc C s | ¡ td | _| jS )Nr )r§ rà r r© r5 r5 r6 r À s z Process.ppidc C s" | ¡ \}}}}}}t |||¡S r ©r¨ r Zpuids)r ÚrealÚ effectiveÚsavedÚ_r5 r5 r6 ÚuidsÅ ó z Process.uidsc C s" | ¡ \}}}}}}t |||¡S r rÒ )r rÖ rÓ rÔ rÕ r5 r5 r6 ÚgidsÊ rØ z Process.gidsc C s t | j| j¡}tj| S r )r3 Zproc_cpu_timesrn r£ r Z pcputimes)r rE r5 r5 r6 rE Ï s
zProcess.cpu_timesc C sP | ¡ td }|d@ d? |d@ B }t d¡D ]}t |¡j|kr%| S qd S )Nr& l ü é iÿÿ z /dev/**/*)r§ rà ÚglobrG rÆ Úst_rdev)r ZttydevÚdevr5 r5 r6 ÚterminalÔ s ÿzProcess.terminalc C sP | j }zt d|| jf ¡}| d¡W S ty' t d|| jf ¡ Y d S w )Nz %s/%s/cwdú/rÅ )r£ rG Úreadlinkrn r° r rÆ )r Z procfs_pathÚresultr5 r5 r6 r· ß s þz Process.cwdc C s2 | ¡ }|td d }|td d }t||S )Nr i r! )r§ rà r' )r rD r r! r5 r5 r6 Ú memory_infoé s
zProcess.memory_infoc C s | ¡ td }t |d¡S )Nr% ú?)r§ rà Ú
PROC_STATUSESr )r Úcoder5 r5 r6 r% ò s zProcess.statusc C sÄ t jddt| jgt jt jd}| ¡ \}}tr#dd ||fD \}}d| ¡ v r0t| j| j t
d|¡}g }|D ]%\}}| ¡ }|
d¡rM|d d
}| ¡ d
krTq:| t |t|¡¡ q:|S ) Nz/usr/bin/procfilesz-nr~ c S rN r5 rO r< r5 r5 r6 r? ÿ rS z&Process.open_files.<locals>.<listcomp>zno such processz (\d+): S_IFREG.*\s*.*name:(.*)\nz//r zcannot be retrieved)rT rU r rn rV rW r Úlowerr r r ÚfindallrZ Ú
startswithre r Z popenfiler )r r^ rL rM Z procfilesrg rw r r5 r5 r6 Ú
open_filesø s( ÿ
ÿ
zProcess.open_filesc C s( | j dkrdS tt d| j| j f ¡S )Nr z%s/%s/fd)rn r\ rG r r£ r© r5 r5 r6 Únum_fds s
zProcess.num_fdsc C s t jt | j¡ S r )r Zpctxswr3 Zproc_num_ctx_switchesrn r© r5 r5 r6 Únum_ctx_switches s
ÿzProcess.num_ctx_switchesNc C s t | j|| j¡S r )r Zwait_pidrn r )r Útimeoutr5 r5 r6 Úwait s z Process.waitc C sR z t | j¡\}}}}W n ty t| js t| j| j w t ||||¡S r ) r3 r rn ÚOSErrorr r r r Zpio)r ÚrcZwcÚrbÚwbr5 r5 r6 Ú io_counters s
ûzProcess.io_counters)rÊ r )&Ú__name__Ú
__module__Ú __qualname__Ú__doc__Ú __slots__r¥ rª r¬ r¡ r r§ r¨ r r¾ r³ r¼ r" r$ Ú HAS_THREADSrÉ rË rÎ rÑ r r× rÙ rE rÞ r· râ Zmemory_full_infor% ré rê rë rí ÚHAS_PROC_IO_COUNTERSrò r5 r5 r5 r6 r¢ J sz
þr¢ )F)rk )erö r rÛ rG r rT rQ Ú collectionsr rb r r r r3 r rÌ r r r
r r r
r r r r Z_compatr r r r Z__extra__all__Úhasattrrø ZHAS_NET_IO_COUNTERSrù Z getpagesizeZ PAGE_SIZEZAF_LINKZSIDLZ STATUS_IDLEZSZOMBZ
STATUS_ZOMBIEZSACTIVEZSTATUS_RUNNINGZSSWAPZSSTOPZSTATUS_STOPPEDrä 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_NONEZ CONN_NONErq Údictrà r' Zpfullmemr( r, r7 r9 rE rA rJ r_ r` Zdisk_io_countersrd rc r r rp r r r r r r¡ Úobjectr¢ r5 r5 r5 r6 Ú<module> s¬
û ôø
%