B "„OcDnãR@sbdZddlmZddlmZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlmZddl mZddl mZddl mZydd l mZWnek rÄdZYnXydd l mZWnek rîdZYnXe jd krddlZndZe jdd kZee d d¡ƒZeƒZddddddddddddddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;dd?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_gRZejd`kZejdakZ e j! "db¡Z#e j! "dc¡Z$e$Z%e j! "dd¡Z&e j! "de¡Z'e j! "df¡Z(e&p8e'p8e(Z)e j! "dg¡Z*e j! "dh¡Z+diZ,djZ-dkZ.dlZ/dmZ0dnZ1doZ2dpZ3dqZ4drZ5dsZ6dtZ7duZ8dvZ9dwZ:dxZ;dyZd|Z?d}Z@d~ZAdZBd€ZCdZDd‚ZEedkrÒdƒZFd„ZGdZHn Gd…d†„d†ejIƒZJeKƒ LeJjM¡edkrd‡ZNdˆZOn Gd‰dŠ„dŠejIƒZPeKƒ LePjM¡e  Q¡ZRes:d‹ZSn2y e  T¡ZSWn$eUk rjerbdŒnd‹ZSYnXedIddŽddd‘d’gƒZVedEddŽddgƒZWedCd“d”d•d–d—d˜gƒZXedDd™dšd›dœddžgƒZYedFdŸd d¡d¢d£d¤d¥d¦gƒZZedJd§d¨d©dªd«gƒZ[edAd¬d­d®d¯d°d±d«gƒZ\edGd­d²d³d´dµgƒZ]edHd¶d·d¸d¹dºgƒZ^edBd»d¼d½d¾gƒZ_ed¿dÀdÁdÂgƒZ`edÃdÄdÀdÅdÆgƒZaedÇddÈdÉgƒZbedÊdÄdÀgƒZced9dËdÌdÍdÎgƒZded>dÏd¬gƒZeed?dÐdÑdÒgƒZfed@dÓdÔdÕgƒZged;dÓdÔdÕgƒZhed|D]6}t||dƒ}|r,|||<q|dkr|dkr|||<qW|S)Nrtr)Ú collectionsÚ OrderedDictÚgetattr)ÚselfZattrsÚinforsrˆrhrhriÚ _infodicts    zError._infodictcCsP| d¡}|r,dd dd„| ¡Dƒ¡}nd}d dd„t|dd ƒ|fDƒ¡S) N)rtÚppidrsz(%s)z, cSsg|]\}}d||f‘qS)z%s=%rrh)Ú.0ÚkÚvrhrhriú +sz!Error.__str__..ú cSsg|] }|r|‘qSrhrh)r”Úxrhrhrir—.sÚmsgÚ)r’ÚjoinÚitemsr)rr‘ÚdetailsrhrhriÚ__str__&s  z Error.__str__cCs2| d¡}d dd„| ¡Dƒ¡}d|jj|fS)N)rtr“rsÚsecondsršz, cSsg|]\}}d||f‘qS)z%s=%rrh)r”r•r–rhrhrir—3sz"Error.__repr__..z psutil.%s(%s))r’rœrÚ __class__re)rr‘ržrhrhriÚ__repr__0s zError.__repr__N)rerfrgÚ__doc__r’rŸr¢rhrhrhrir‹s   r‹c@seZdZdZdZddd„ZdS)Ú NoSuchProcesszXException raised when a process with a certain PID doesn't or no longer exists. rŒNcCs$t |¡||_||_|pd|_dS)Nzprocess no longer exists)r‹Ú__init__rtrsrš)rrtrsršrhrhrir¥=s zNoSuchProcess.__init__)NN)rerfrgr£r¥rhrhrhrir¤7sr¤c@seZdZdZdZddd„ZdS)Ú ZombieProcessa1Exception 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ŒNcCs$t ||||¡||_|pd|_dS)Nz"PID still exists but it's a zombie)r¤r¥r“rš)rrtrsr“ršrhrhrir¥MszZombieProcess.__init__)NNN)rerfrgr£r¥rhrhrhrir¦Dsr¦c@seZdZdZdZddd„ZdS)Ú AccessDeniedz@Exception raised when permission to perform an action is denied.rŒNcCs$t |¡||_||_|pd|_dS)Nr›)r‹r¥rtrsrš)rrtrsršrhrhrir¥Ws zAccessDenied.__init__)NNN)rerfrgr£r¥rhrhrhrir§Ssr§c@seZdZdZdZddd„ZdS)ÚTimeoutExpiredzWRaised on Process.wait(timeout) if timeout expires and process is still alive. rŒNcCs*t |¡||_||_||_d||_dS)Nztimeout after %s seconds)r‹r¥r rtrsrš)rr rtrsrhrhrir¥ds  zTimeoutExpired.__init__)NN)rerfrgr£r¥rhrhrhrir¨^sr¨cCsDyt|ƒ|d}Wntk r(dSX|dk r>> @memoize ... def foo() ... return 1 ... >>> foo() 1 >>> foo.cache_clear() >>> csH|tt| ¡ƒƒf}yˆ|Stk rBˆ||Ž}ˆ|<|SXdS)N)Ú frozensetÚsortedrÚKeyError)ÚargsÚkwargsÚkeyr­)ÚcacheÚfunrhriÚwrapper‹s zmemoize..wrappercs ˆ ¡dS)z Clear cache.N)Úclearrh)r´rhriÚ cache_clear”szmemoize..cache_clear)Ú functoolsÚwrapsr¸)rµr¶r¸rh)r´rµrirL}s  cs6t ˆ¡‡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 sjy|jˆ}WnVtk r&ˆ|ƒStk rdˆ|ƒ}y||jˆ<Wntk r^YnXYnX|S)N)Ú_cacheÚAttributeErrorr°)rr­)rµrhrir¶·s z'memoize_when_activated..wrappercSs i|_dS)zjActivate cache. Expects a Process instance. Cache will be stored as a "_cache" instance attribute.N)r»)ÚprocrhrhriÚcache_activateËsz.memoize_when_activated..cache_activatecSs"y|`Wntk rYnXdS)zDeactivate and clear cache.N)r»r¼)r½rhrhriÚcache_deactivateÐsz0memoize_when_activated..cache_deactivate)r¹rºr¾r¿)rµr¶r¾r¿rh)rµriÚmemoize_when_activateds rÀc CsVyt |¡}Wn6tk rD}z|jtjtjfkr4‚dSd}~XYnXt |j¡SdS)zœSame as os.path.isfile() but does not swallow EACCES / EPERM exceptions, see: http://mail.python.org/pipermail/python-dev/2012-June/120787.html FN)ÚosÚstatÚOSErrorÚerrnoÚEPERMÚEACCESÚS_ISREGÚst_mode)r…ÚstÚerrrhrhrirKÜsc CsNyt |¡Wn6tk rD}z|jtjtjfkr4‚dSd}~XYnXdSdS)zœSame as os.path.exists() but does not swallow EACCES / EPERM exceptions, see: http://mail.python.org/pipermail/python-dev/2012-June/120787.html FNT)rÁrÂrÃrÄrÅrÆ)r…rÊrhrhrirNësc Cs`tjrtdkrdSy2t ttj¡}t |¡| d¡WdQRXdStjk rZdSXdS)z2Return True if IPv6 is supported on this platform.NF)z::1rT)ÚsocketZhas_ipv6rrÚ contextlibÚclosingZbindÚerror)ZsockrhrhrirPús cCszi}d}t}xh| d|¡}||kr$P| d||¡}||krj|||…}||d|…}|rb| ¡}|||<|d}qW|S)zCParse a C environ block of environment variables into a dictionary.rúú=rc)rÚfindÚupper)Údatar­ÚposZWINDOWS_Znext_posZ equal_posr³rˆrhrhrirMs    cCs0tdkr |Sy t |¡Stk r*|SXdS)zConvert a numeric socket family value to an IntEnum member. If it's not a known member, return the numeric value itself. N)ÚenumrËZ AddressFamilyÚ ValueError)ÚnumrhrhrirQ$s  cCs0tdkr |Sy t |¡Stk r*|SXdS)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ËZ SocketKindrÖ)r×rhrhrirR1s  cCs|tjtfkr&|rt|Ž}|r&t|Ž}|tjkrJ|ttfkrJ| |t¡}nt}t|ƒ}t|ƒ}|dkrxt ||||||ƒSt |||||||ƒSdS)z2Convert a raw connection tuple to a proper ntuple.N) rËrrr‰rÚgetrrQrRr6r?)ruZfamZtype_rwrxryZ status_maprtrhrhrirY>scs‡fdd„}|S)zƒA decorator which can be used to mark a method as deprecated 'replcement' is the method name which will be called instead. cs:d|jˆf‰|jdkrˆ|_t |¡‡‡fdd„ƒ}|S)Nz8%s() is deprecated and will be removed; use %s() insteadcs tjˆtddt|ˆƒ||ŽS)Nrb)ÚcategoryÚ stacklevel)ÚwarningsÚwarnÚDeprecationWarningr)rr±r²)ršÚ replacementrhriÚinner[sz/deprecated_method..outer..inner)rer£r¹rº)rµrß)rÞ)ršriÚouterUs   z deprecated_method..outerrh)rÞràrh)rÞrirJQs c@sBeZdZdZdd„Zdd„Zdd„Zdd „Zdd d „Zd d„Z d S)Ú _WrapNumberszNWatches numbers so that they don't overflow and wrap (reset to zero). cCs t ¡|_i|_i|_i|_dS)N)Ú threadingZLockÚlockr´Ú remindersÚ reminder_keys)rrhrhrir¥hs z_WrapNumbers.__init__cCsX||jkst‚||jkst‚||jks*t‚||j|<t t¡|j|<t t¡|j|<dS)N)r´ÚAssertionErrorrärårÚ defaultdictÚintÚset)rÚ input_dictrsrhrhriÚ _add_dictns  z_WrapNumbers._add_dictcCsd|j|}t| ¡ƒt| ¡ƒ}x<|D]4}x"|j||D]}|j||=qYnXg}xvtt|ƒƒD]f} || } || } || f} | | krÖ|j|| | 7<|j||  | ¡|  | |j|| ¡qˆWt |ƒ||<q>W||j|<|S)zkCache dict and sum numbers which overflow and wrap. Return an updated copy of `input_dict` ) r´rërïrìr°ÚrangeÚlenräråÚaddÚappendÚtuple) rrêrsríZnew_dictr³Z input_tupleZ old_tupleÚbitsÚiZ input_valueÚ old_valuerîrhrhriÚruns2      z_WrapNumbers.runNc Csh|jX|dkr0|j ¡|j ¡|j ¡n*|j |d¡|j |d¡|j |d¡WdQRXdS)z>Clear the internal cache, optionally only for function 'name'.N)rãr´r·räråÚpop)rrsrhrhrir¸¨s   z_WrapNumbers.cache_clearc Cs"|j|j|j|jfSQRXdS)z5Return internal cache dicts as a tuple of 3 elements.N)rãr´rärå)rrhrhriÚ cache_info´sz_WrapNumbers.cache_info)N) rerfrgr£r¥rërïrør¸rúrhrhrhrirács ' rác Cstjt ||¡SQRXdS)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ãrø)rêrsrhrhrirSºsi€cCst|dtdS)NÚrb)Ú buffering)ÚopenÚFILE_READ_BUFFER_SIZE)ÚfnamerhrhrirU×scCsdtst|dtdSt|dtttd}y t|_Wn0tk rBYntk r^| ¡‚YnX|S)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'). Zrt)rý)rýÚencodingÚerrors) ÚPY3rþrÿr4r5Ú _CHUNK_SIZEr¼Ú ExceptionÚclose)rZfobjrhrhrirTÛs  c Cs\|tkr"||ƒ }| ¡SQRXn6y||ƒ }| ¡SQRXWnttfk rV|SXdS)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ÚfrhrhrirVõs  cCst||tdS)z,Same as above but opens file in binary mode.)r r )rVrU)rr rhrhrirWsú%(value).1f%(symbol)scCsŽd}i}x0t|dd…ƒD]\}}d|dd>||<qWx>t|dd…ƒD]*}|||krLt|ƒ||}|tƒSqLW|t|d|dS)zŒUsed by various scripts. See: http://goo.gl/zeJZl >>> bytes2human(10000) '9.8K' >>> bytes2human(100001221) '95.4M' ) ÚBÚKÚMÚGÚTÚPÚEÚZÚYrcNé r)Úsymbolrˆ)Ú enumerateÚreversedrªÚlocalsÚdict)ÚnÚformatZsymbolsÚprefixröÚsrrˆrhrhrirX s  cCs tjdjS)z+Return updated psutil.PROCFS_PATH constant.rŒ)ÚsysÚmodulesZ PROCFS_PATHrhrhrhriÚget_procfs_pathsr#cCs|jttdS)N)rr)Údecoder4r5)r rhrhrir$%sr$cCs|S)Nrh)r rhrhrir$(scCs^tjdkrdSy2ddl}| ¡s$t‚| ¡| d¡dks>t‚Wntk rTdSXdSdS)Nr_TrÚcolorsF)rÁrsÚcursesÚisattyræZ setuptermZtigetnumr)Úfiler&rhrhrir\1s  Fc Cstƒs |Sg}tddddddddd d }d |d <y ||}Wn(tk rdtd t| ¡ƒƒ‚YnX| |¡|r~| d¡dd |¡|fS)z*Return an highlighted version of 'string'.Z32Z91Z33Z93Z34Z35Z36Z37Z30) ÚgreenÚredÚbrownÚyellowZblueZvioletZ lightblueZgreyZdarkgreyZ29Nz#invalid color %r; choose between %sÚ1z [%sm%sú;)r\rr°rÖÚlistrìrórœ)r ÚcolorÚboldÚattrr%rhrhrir[@s    c Cstƒst||dnêtr.tt|||ƒ|dnÐddl}d}|jjj}|jjj}t ddddd}||d<y ||}Wn,t k ržt d |t |  ¡ƒfƒ‚YnX|r´|dkr´|d 7}|tjkrÂd nd } |j|_|| ƒ} || |ƒzt||dWd|| |ƒXdS) z$Print a colorized version of string.)r(rNérbr é)r)r*r+r,z#invalid color %r; choose between %réiôÿÿÿiõÿÿÿ)r\Úprintrr[ÚctypesZwindllZKernel32Ú GetStdHandleÚSetConsoleTextAttributerr°rÖr/rìr!ÚstderrZc_ulongZrestype) r r0r1r(r7Z DEFAULT_COLORr8r9r%Z handle_idZhandlerhrhrir]Ss0     cCsntrjddl}| | ¡j¡\}}}}}t|tƒrRt|ttt fƒrJd|}nd|}t d|||ft j ddS)z@If PSUTIL_DEBUG env var is set, print a debug message to stderr.rNz ignoring %sz ignoring %rzpsutil-debug [%s:%s]> %s)r() r ÚinspectZ getframeinfoZ currentframeÚf_backÚ isinstancerrÃr ÚEnvironmentErrorr6r!r:)ršr;rÚlinenoZ func_nameÚlinesÚindexrhrhrirZvs  )N)N)r )NF)’r£Z __future__rrrrÌrÄr¹rÁrËrÂr!rârÛrrrrrÚ ImportErrorr Ú version_inforÕrÚboolÚgetenvr ÚobjectrÚ__all__rsrrÚplatformÚ startswithrrrr rrrrZAIXr*r+r'r,r.r2r&r0r1r(r)r/r-r3rr!r rrr"rrrrrrr#r$r%ÚIntEnumrdÚglobalsÚupdateÚ __members__rmrnrlÚgetfilesystemencodingr4r5Úgetfilesystemencodeerrorsr¼rGrCrArBrDrHr?rErFr@r{r~rr€r7r<r=r>r9r:r;r8r6r‰rIrr‹r¤r¦r§r¨rOrLrÀrKrNrPrMrQrRrYrJrárSrûr¸rúrÿrUrTrVrWrXr#r$Ústdoutr\r[r]rZrhrhrhriÚs†                                         !    ?   W     "