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$n ã
@ s2 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 eya dZY nw zdd
l mZ W n eyu dZY nw e jd krddlZndZe jd d kZee d
d¡Ze Z g d¢Z ej dkZ ej dkZ e j! "d¡Z#e j! "d¡Z$e$Z%e j! "d¡Z&e j! "d¡Z'e j! "d¡Z(e&pÇe'pÇe(Z)e j! "d¡Z*e j! "d¡Z+dZ,dZ-dZ.dZ/d Z0d Z1d Z2d Z3d Z4d!Z5d"Z6d#Z7d$Z8d%Z9d&Z:d'Z;d(Z<d)Z=d*Z>d+Z?d,Z@d-ZAd.ZBd/ZCd0ZDd1ZEedu rd2ZFd3ZGdZHnG d4d5 d5ejIZJeK LeJjM¡ edu r.d6ZNd7ZOnG d8d9 d9ejIZPeK LePjM¡ e Q¡ ZResHd:ZSnze T¡ ZSW n eUy_ e r[d;nd:ZSY nw ed<g d=¢ZVed>g d?¢ZWed@g dA¢ZXedBg dC¢ZYedDg dE¢ZZedFg dG¢Z[edHg dI¢Z\edJg dK¢Z]edLg dM¢Z^edNg dO¢Z_edPg dQ¢Z`edRg dS¢ZaedTg dU¢ZbedVdWdXgZcedYg dZ¢Zded[d\d]gZeed^g d_¢Zfed`g da¢Zgedbg da¢Zhedcg dd¢ZiededfdggZjedhdidjgZkedkg dl¢ZledmdndogZmeeegeegfeegegfegegfeegegfegegfeegeegfegeegfegeegfdpZnedurQen Legegfegegfdq¡ edurben Ldregeegfi¡ G dsdt dteoZpG dudv dvepZqG dwdx dxeqZrG dydz dzepZsG d{d| d|epZtd±d}d~Zudd Zvdd Zwdd Zxd
d Zyevdd Zzdd Z{dd Z|dd Z}d±ddZ~dd ZG dd dZdd Ze Zeje_eje_dZ
dd Zdd Ze efddZe fddZd²d¡d¢Zd£d¤ Zerød¥d¦ Znd§d¦ Zeve jfd¨d©Zd³d«d¬Zddªe jfdd®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)é é r
Ú PSUTIL_DEBUG)RÚFREEBSDÚBSDÚLINUXÚNETBSDÚOPENBSDÚMACOSÚOSXÚPOSIXÚSUNOSÚWINDOWSÚ
CONN_CLOSEÚCONN_CLOSE_WAITÚ CONN_CLOSINGÚCONN_ESTABLISHEDÚCONN_FIN_WAIT1ÚCONN_FIN_WAIT2Ú
CONN_LAST_ACKÚ CONN_LISTENÚ CONN_NONEÚ
CONN_SYN_RECVÚ
CONN_SYN_SENTÚCONN_TIME_WAITÚNIC_DUPLEX_FULLÚNIC_DUPLEX_HALFÚNIC_DUPLEX_UNKNOWNÚ STATUS_DEADÚSTATUS_DISK_SLEEPÚ STATUS_IDLEÚ
STATUS_LOCKEDÚSTATUS_RUNNINGÚSTATUS_SLEEPINGÚSTATUS_STOPPEDÚSTATUS_SUSPENDEDÚSTATUS_TRACING_STOPÚSTATUS_WAITINGÚSTATUS_WAKE_KILLÚ
STATUS_WAKINGÚ
STATUS_ZOMBIEÚ
STATUS_PARKEDÚENCODINGÚ
ENCODING_ERRSr ÚpconnÚ pcputimesÚpctxswÚpgidsÚpioÚpioniceÚ popenfileÚpthreadÚpuidsÚsconnÚ scpustatsÚsdiskioÚ sdiskpartÚ
sdiskusageÚsnetioÚsnicaddrÚ snicstatsÚsswapÚsuserÚ conn_tmapÚdeprecated_methodÚ
isfile_strictÚmemoizeÚparse_environ_blockÚpath_exists_strictÚ
usage_percentÚ
supports_ipv6Úsockfam_to_enumÚsocktype_to_enumÚ wrap_numbersÚ open_textÚ open_binaryÚcatÚbcatÚ bytes2humanÚconn_to_ntupleÚdebugÚhiliteÚterm_supports_colorsÚ print_colorÚposixÚntÚlinuxÚdarwin)ZfreebsdZ midnightbsdZopenbsdZnetbsd)ÚsunosÚsolarisÚaixÚrunningZsleepingz
disk-sleepÚstoppedz tracing-stopZzombieZdeadz wake-killZwakingÚidleÚlockedZwaitingZ suspendedZparkedZ ESTABLISHEDZSYN_SENTZSYN_RECVZ FIN_WAIT1Z FIN_WAIT2Z TIME_WAITZCLOSEZ
CLOSE_WAITZLAST_ACKZLISTENZCLOSINGÚNONEé é c @ s e Zd ZdZdZdZdS )Ú NicDuplexrj rk r N)Ú__name__Ú
__module__Ú __qualname__r# r$ r% © rp rp ú5/tmp/pip-target-wec6zj2z/lib/python/psutil/_common.pyrl s rl éÿÿÿÿéþÿÿÿc @ s e Zd ZdZdZdS )Ú BatteryTimerr rs N)rm rn ro ÚPOWER_TIME_UNKNOWNÚPOWER_TIME_UNLIMITEDrp rp rp rq rt s rt ÚreplaceÚsurrogateescaperG )ÚtotalÚusedÚfreeÚpercentÚsinZsoutrC )ry rz r{ r| rA )Ú
read_countÚ write_countÚ
read_bytesÚ write_bytesZ read_timeZ
write_timerB )ZdeviceZ
mountpointZfstypeÚoptsZmaxfileZmaxpathrD )Z
bytes_sentZ
bytes_recvZ packets_sentZ packets_recvZerrinZerroutZdropinZdropoutrH )ÚnameZterminalÚhostÚstartedÚpidr? )ÚfdÚfamilyÚtypeÚladdrÚraddrÚstatusr rE )r ÚaddressÚnetmaskÚ broadcastZptprF )ZisupZduplexÚspeedZmtur@ )Z ctx_switchesZ
interruptsZsoft_interruptsZsyscallsÚscpufreq)ÚcurrentÚminÚmaxÚshwtemp)Úlabelr ÚhighÚcriticalÚsbattery)r| ZsecsleftZ
power_pluggedÚsfanr r r7 )ÚuserÚsystemÚ
children_userÚchildren_systemr< Úpathr r= )ÚidZ user_timeZ system_timer> )ÚrealZ effectiveÚsavedr9 r: )r~ r r r r; ZioclassÚvaluer8 Z voluntaryZ involuntaryr6 )r r r r r r ÚaddrÚipÚport)ÚallZtcpZtcp4ZudpZudp4ZinetZinet4Zinet6)Ztcp6Zudp6Úunixc @ s, e Zd ZdZdZdd Zdd Zdd Zd S )
ÚErrorzQBase exception class. All other psutil exceptions inherit
from this one.
Úpsutilc C sH t ¡ }|D ]}t| |d }|r|||< q|dkr!|dkr!|||< q|S )Nr r )Ú collectionsÚ OrderedDictÚgetattr)ÚselfÚattrsÚinfor r£ rp rp rq Ú _infodict s
zError._infodictc C sP | d¡}|rdd dd | ¡ D ¡ }nd }d dd t| dd |fD ¡S )
N)r Úppidr z(%s)ú, c S ó g | ]
\}}d ||f qS ©z%s=%rrp ©Ú.0ÚkÚvrp rp rq Ú
<listcomp>* ó z!Error.__str__.<locals>.<listcomp>ú c S s g | ]}|r|qS rp rp )r· Úxrp rp rq rº - s ÚmsgÚ )r± ÚjoinÚitemsr ©r® r° Údetailsrp rp rq Ú__str__% s
ÿ z
Error.__str__c C s2 | d¡}d dd | ¡ D ¡}d| jj|f S )N)r r² r Úsecondsr¾ r³ c S r´ rµ rp r¶ rp rp rq rº 2 r» z"Error.__repr__.<locals>.<listcomp>z
psutil.%s(%s))r± rÀ rÁ Ú __class__rm r rp rp rq Ú__repr__/ s
zError.__repr__N)rm rn ro Ú__doc__r± rÄ rÇ rp rp rp rq r© s
r© c @ ó e Zd ZdZdZdddZdS )Ú
NoSuchProcesszXException raised when a process with a certain PID doesn't
or no longer exists.
rª Nc C ó$ t | ¡ || _|| _|pd| _d S )Nzprocess no longer exists©r© Ú__init__r r r¾ ©r® r r r¾ rp rp rq rÍ < ó
zNoSuchProcess.__init__©NN©rm rn ro rÈ rÍ rp rp rp rq rÊ 6 ó rÊ c @ rÉ )Ú
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 | |||¡ || _|pd| _d S )Nz"PID still exists but it's a zombie)rÊ rÍ r² r¾ )r® r r r² r¾ rp rp rq rÍ L s zZombieProcess.__init__©NNNrÑ rp rp rp rq rÓ C s rÓ c @ rÉ )Ú AccessDeniedz@Exception raised when permission to perform an action is denied.rª Nc C rË )Nr¿ rÌ rÎ rp rp rq rÍ V rÏ zAccessDenied.__init__rÔ rÑ rp rp rp rq rÕ R s rÕ c @ rÉ )Ú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 rp rp rq rÍ c s
zTimeoutExpired.__init__rÐ rÑ rp rp rp rq rÖ ] rÒ rÖ c C s@ z
t | | d }W n
ty Y dS w |dur t||}|S )z5Calculate percentage usage of 'used' against 'total'.éd g N)ÚfloatÚZeroDivisionErrorÚround)rz ry Zround_Úretrp rp rq rO p s ÿ
rO 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()
>>>
c sL | t t| ¡ f}z | W S ty% | i |¤ } |< | Y S w ©N)Ú frozensetÚsortedrÁ ÚKeyError)ÚargsÚkwargsÚkeyrÛ ©ÚcacheÚfunrp rq Úwrapper s
þzmemoize.<locals>.wrapperc s ¡ dS )z Clear cache.N)Úclearrp )rä rp rq Ú cache_clear ó z memoize.<locals>.cache_clearN)Ú functoolsÚwrapsrè )rå ræ rè rp rã rq rL | s rL 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 sj z| j }W |S ty | Y S ty4 | }z || j < W Y |S ty3 Y Y |S w w rÜ )Ú_cacheÚAttributeErrorrß )r® rÛ ©rå rp rq ræ ¶ s ó üüúz'memoize_when_activated.<locals>.wrapperc S s
i | _ dS )zjActivate cache. Expects a Process instance. Cache will be
stored as a "_cache" instance attribute.N)rì ©Úprocrp rp rq Úcache_activateÊ s
z.memoize_when_activated.<locals>.cache_activatec S s z| ` W dS ty Y dS w )zDeactivate and clear cache.N)rì rí rï rp rp rq Úcache_deactivateÏ s
ÿz0memoize_when_activated.<locals>.cache_deactivateN)rê rë rñ rò )rå ræ rñ rò rp rî rq Úmemoize_when_activated s ró c
C sV zt | ¡}W n ty$ } z|jtjtjfv r W Y d}~dS d}~ww t |j¡S )zSame as os.path.isfile() but does not swallow EACCES / EPERM
exceptions, see:
http://mail.python.org/pipermail/python-dev/2012-June/120787.html
NF)ÚosÚstatÚOSErrorÚerrnoÚEPERMÚEACCESÚS_ISREGÚst_mode)r ÚstÚerrrp rp rq rK Û s ý rK c
C sL zt | ¡ W dS ty% } z|jtjtjfv r W Y d}~dS d}~ww )zSame as os.path.exists() but does not swallow EACCES / EPERM
exceptions, see:
http://mail.python.org/pipermail/python-dev/2012-June/120787.html
NFT)rô rõ rö r÷ rø rù )r rý rp rp rq rN ê s ûýrN c C sv t jrtdu r dS z&t tt j¡} t | ¡ | d¡ W d W dS 1 s(w Y W dS t jy: Y dS w )z2Return True if IPv6 is supported on this platform.NF)z::1r T)ÚsocketÚhas_ipv6r r Ú
contextlibÚclosingÚbindÚerror)Úsockrp rp rq rP ù s
ÿþÿrP c C sx i }d}t } | d|¡}||kr |S | d||¡}||kr7| ||
}| |d |
}|r3| ¡ }|||< |d }q)zCParse a C environ block of environment variables into a dictionary.r Tú ú=rk N)r ÚfindÚupper)ÚdatarÛ ÚposZWINDOWS_Znext_posZ equal_posrâ r£ rp rp rq rM s" ö òrM c C ó0 t du r| S zt | ¡W S ty | Y S w )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Ú
ValueError©Únumrp rp rq rQ # ó ÿrQ c C r )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 rp rp rq rR 0 r rR c C s |t jtfv r|r
t| }|rt| }|t jkr%|ttfv r%| |t¡}nt}t|}t|}|du r<t | |||||S t
| ||||||S )z2Convert a raw connection tuple to a proper ntuple.N) rþ r r r¤ r Úgetr rQ rR r6 r? )r ÚfamÚtype_r r r Z
status_mapr rp rp rq rY = s rY 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 u r | _t | ¡ fdd}|S )Nz8%s() is deprecated and will be removed; use %s() insteadc s$ t j tdd t| |i |¤S )Nrj )ÚcategoryÚ
stacklevel)ÚwarningsÚwarnÚDeprecationWarningr )r® rà rá )r¾ Ú replacementrp rq ÚinnerZ s z/deprecated_method.<locals>.outer.<locals>.inner)rm rÈ rê rë )rå r ©r )r¾ rq ÚouterT s ÿ
z deprecated_method.<locals>.outerNrp )r r rp r rq rJ P s rJ 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Ü )Ú threadingÚLockÚlockrä Ú remindersÚ
reminder_keys©r® rp rp rq rÍ g s
z_WrapNumbers.__init__c C sX || j vsJ || jvsJ || jvsJ || j |< t t¡| j|< t t¡| j|< d S rÜ )rä r# r$ r« Ú defaultdictÚintÚset)r® Ú
input_dictr rp rp rq Ú _add_dictm s
z_WrapNumbers._add_dictc C s\ | j | }t| ¡ t| ¡ }|D ]}| j| | D ]}| j| |= q | j| |= qdS )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_keyÚremkeyrp rp rq Ú_remove_dead_remindersu s
ýz#_WrapNumbers._remove_dead_remindersc
C s || j vr
| ||¡ |S | ||¡ | j | }i }| ¡ D ]\}|| }z|| }W n
ty7 |||< Y q w g }tt|D ]3} || }
|| } || f} |
| k rg| j| | | 7 < | j| | | ¡ |
|
| j| | ¡ q@t |||< q || j |< |S )zkCache dict and sum numbers which overflow and wrap.
Return an updated copy of `input_dict`
N) rä r* r. r+ rß ÚrangeÚlenr# r$ ÚaddÚappendÚtuple)
r® r) r r, Znew_dictrâ Z input_tupleZ old_tupleÚbitsÚiZ input_valueÚ old_valuer- rp rp rq Úrun s4
ü
z_WrapNumbers.runNc C s | j : |du r| j ¡ | j ¡ | j ¡ n | j |d¡ | j |d¡ | j |d¡ W d dS W d dS 1 s@w Y dS )z>Clear the internal cache, optionally only for function 'name'.N)r" rä rç r# r$ Úpop)r® r rp rp rq rè § s
ø"üz_WrapNumbers.cache_clearc C s: | j | j| j| jfW d S 1 sw Y dS )z5Return internal cache dicts as a tuple of 3 elements.N)r" rä r# r$ r% rp rp rq Ú
cache_info³ s $ÿz_WrapNumbers.cache_inforÜ )
rm rn ro rÈ rÍ r* r. r7 rè r9 rp rp rp rq r b s
' r c C s6 t j t | |¡W d S 1 sw Y dS )zÅGiven 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" r7 )r) r rp rp rq rS ¹ s
$ÿrS i c C s t | dtdS )NÚrb©Ú buffering)ÚopenÚFILE_READ_BUFFER_SIZE)Úfnamerp rp rq rU Ö ó rU c C s\ t s t| dtdS t| dtttd}zt|_W |S ty" Y |S ty- | ¡ w )z¨On 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').
Úrtr< )r= ÚencodingÚerrorsN) ÚPY3r> r? r4 r5 Ú _CHUNK_SIZErí Ú ExceptionÚclose)r@ Zfobjrp rp rq rT Ú s ÿ ú üþrT c C s |t u r || }| ¡ W d S 1 sw Y dS z ||
}| ¡ W d W S 1 s3w Y W dS ttfyG | Y S w )zÛRead 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)Ú_DEFAULTÚreadÚIOErrorrö )r@ ÚfallbackÚ_openÚfrp rp rq rV ô s
$ÿ
(ÿÿrV c C s t | |tdS )z,Same as above but opens file in binary mode.)rL rM N)rV rU )r@ rL rp rp rq rW s rW ú%(value).1f%(symbol)sc C s d}i }t |dd
D ]\}}d|d d > ||< q t|dd
D ]}| || kr:t| || }|t S q#|t|d | d S )zUsed by various scripts. See:
http://goo.gl/zeJZl
>>> bytes2human(10000)
'9.8K'
>>> bytes2human(100001221)
'95.4M'
) ÚBÚKÚMÚGÚTÚPÚEÚZÚYrk Né
r )Úsymbolr£ )Ú enumerateÚreversedrØ ÚlocalsÚdict)ÚnÚformatÚsymbolsÚprefixr5 ÚsrZ r£ rp rp rq rX
s þrX c C s t jd jS )z+Return updated psutil.PROCFS_PATH constant.rª N)ÚsysÚmodulesZ PROCFS_PATHrp rp rp rq Úget_procfs_path ré rf c C s | j ttdS )N)rC rD )Údecoder4 r5 ©rc rp rp rq rg $ rA rg c C s | S rÜ rp rh rp rp rq rg ' s c C sX t jdkrdS zdd l}| ¡ sJ | ¡ | d¡dks J W dS ty+ Y dS w )Nr_ Tr ÚcolorsF)rô r ÚcursesÚisattyZ setuptermZtigetnumrG )Úfilerj rp rp rq r\ 0 s
ýÿr\ Fc C s t s| S g }tddddddddd d
}d |d < z|| }W n ty/ td
t| ¡ w | |¡ |r<| d¡ dd |¡| f S )z*Return an highlighted version of 'string'.Z32Z91Z33Z93Z34Z35Z36Z37Z30) ÚgreenÚredÚbrownÚyellowÚblueZvioletZ lightblueZgreyZdarkgreyZ29Nz#invalid color %r; choose between %sÚ1z [%sm%s[0mú;)r\ r^ rß r Úlistr+ r2 rÀ )rc ÚcolorÚboldÚattrri rp rp rq r[ ? s$ ÿ
ÿÿ
r[ c C s t s t| |d dS trtt| |||d dS ddl}d}|jjj}|jjj}t ddddd}||d< z|| }W n t
yN t d |t |
¡ f w |rY|dkrY|d
7 }|tju r`d nd } |j|_|| }
||
| zt| |d W ||
| dS ||
| w )
z$Print a colorized version of string.©rl r Né rj r é )rm rn ro rp z#invalid color %r; choose between %ré iôÿÿÿiõÿÿÿ)r\ Úprintr r[ ÚctypesÚwindllZKernel32Ú GetStdHandleÚSetConsoleTextAttributer^ rß r rt r+ rd ÚstderrÚc_ulongÚrestype) rc ru rv rl r} Z
DEFAULT_COLORr r ri Z handle_idÚhandlerp rp rq r] R s6
ÿ ÿÿ
r] c C sr t r7ddl}| | ¡ j¡\}}}}}t| tr)t| ttt fr%d| } nd| } t
d||| f t j d dS dS )z@If PSUTIL_DEBUG env var is set, print a debug message to stderr.r Nz ignoring %sz ignoring %rzpsutil-debug [%s:%s]> %srx )
r ÚinspectÚ getframeinfoÚ currentframeÚf_backÚ
isinstancerG rö rK ÚEnvironmentErrorr| rd r )r¾ r
r@ ÚlinenoÚ func_nameÚlinesÚindexrp rp rq rZ u s ÿ
ÿörZ rÜ )rO )NF)rÈ Ú
__future__r r r« r r÷ rê rô rþ rõ rd r r r r r r r Ú ImportErrorr Ú version_infor rE ÚboolÚgetenvr ÚobjectrI Ú__all__r r r ÚplatformÚ
startswithr r r r
r r r r ZAIXr* r+ r' r, r. r2 r& r0 r1 r( r) r/ r- r3 r r! r r r r" r r r r r r r# r$ r% ÚIntEnumrl ÚglobalsÚupdateÚ __members__ru rv rt Úgetfilesystemencodingr4 r5 Úgetfilesystemencodeerrorsrí rG rC rA rB rD rH r? rE rF r@ r r r r r7 r< r= r> r9 r: r; r8 r6 r¤ rI rG r© rÊ rÓ rÕ rÖ rO rL ró rK rN rP rM rQ rR rY rJ r rS r: rè r9 r? rU rT rV rW rX rf rg Ústdoutr\ r[ r] rZ rp rp rp rq Ú<module> sd ÿ ÿ
%
ÿ ÿÿÿÿ
ø
þ
ÿ
!
?
W
ÿ #