o jĎib @s(dZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddlm Z ddlm Z ddlm Z zddlm Z Wn eyKdZ YnwzddlmZWn ey_dZYnweedZeZgd Zejd kZejd kZejd Zejd ZeZejdZejdZejdZ epepe Z!ejdZ"ejdZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0d Z1d!Z2d"Z3d#Z4d$Z5d%Z6d&Z7d'Z8d(Z9d)Z:d*Z;d+ZZ?e@Ae?jBGd/d0d0ej>ZCe@AeCjBeDZEeFZGe e ege e gfe e ge gfe ge gfe e ge gfe ge gfe e ge e gfe ge e gfe ge e gfd1ZHe durOeHAe ge gfe ge gfd2edurce"sceHAd3ege e gfiGd4d5d5eIZJGd6d7d7eJZKGd8d9d9eKZLGd:d;d;eJZMGdd?ZOd@dAZPdBdCZQdDdEZRdFdGZSdHdIZTdJdKZUdLdMZVdNdOZWdsdPdQZXdRdSZYdTdUZZGdVdWdWZ[dXdYZ\e[Z]e]j^e\_^e]j_e\__dZZ`d[d\Zad]d^Zbeebfd_d`ZcefdadbZddtdddeZedfdgZfdhdiZgePejhfdjdkZidudmdnZjddlejhfdodpZkdqdrZldS)vzCommon objects shared by __init__.py and _ps*.py modules. Note: this module is imported by setup.py, so it should not import psutil or third-party modules. N)AF_INET) SOCK_DGRAM) SOCK_STREAM)AF_INET6)AF_UNIX PSUTIL_DEBUG)?FREEBSDBSDLINUXNETBSDOPENBSDMACOSOSXPOSIXSUNOSWINDOWS CONN_CLOSECONN_CLOSE_WAIT CONN_CLOSINGCONN_ESTABLISHEDCONN_FIN_WAIT1CONN_FIN_WAIT2 CONN_LAST_ACK CONN_LISTEN CONN_NONE CONN_SYN_RECV CONN_SYN_SENTCONN_TIME_WAITNIC_DUPLEX_FULLNIC_DUPLEX_HALFNIC_DUPLEX_UNKNOWN STATUS_DEADSTATUS_DISK_SLEEP STATUS_IDLE STATUS_LOCKEDSTATUS_RUNNINGSTATUS_SLEEPINGSTATUS_STOPPEDSTATUS_SUSPENDEDSTATUS_TRACING_STOPSTATUS_WAITINGSTATUS_WAKE_KILL STATUS_WAKING STATUS_ZOMBIE STATUS_PARKEDENCODING ENCODING_ERRSr conn_tmapdeprecated_method isfile_strictmemoizeparse_environ_blockpath_exists_strict usage_percent supports_ipv6sockfam_to_enumsocktype_to_enum wrap_numbers open_text open_binarycatbcat bytes2humanconn_to_ntupledebughiliteterm_supports_colors print_colorposixntlinuxdarwin)freebsd midnightbsdopenbsdnetbsd)sunossolarisaixrunningsleepingz disk-sleepstoppedz tracing-stopzombiedeadz wake-killwakingidlelockedwaiting suspendedparked ESTABLISHEDSYN_SENTSYN_RECV FIN_WAIT1 FIN_WAIT2 TIME_WAITCLOSE CLOSE_WAITLAST_ACKLISTENCLOSINGNONEc@seZdZdZdZdZdS) NicDuplexrN)__name__ __module__ __qualname__rrr rnrnJ/home/jeff/fluffinator/venv/lib/python3.10/site-packages/psutil/_common.pyrhzsrhc@seZdZdZdZdS) BatteryTimeN)rkrlrmPOWER_TIME_UNKNOWNPOWER_TIME_UNLIMITEDrnrnrnrorpsrp)alltcptcp4udpudp4inetinet4inet6)tcp6udp6unixc@s,eZdZdZdZddZddZddZd S) ErrorzQBase exception class. All other psutil exceptions inherit from this one. psutilcCs>t}|D]}t||d}|s|dkr|dkr|||<q|S)Npidr) collections OrderedDictgetattr)selfattrsinfonamevaluernrnro _infodicts zError._infodictcCsR|d}|rdddd|D}nd}dddt|dd |fDS) N)rppidrz({}), cSg|] \}}|d|qS=rn.0kvrnrnro z!Error.__str__.. cSsg|]}|r|qSrnrn)rxrnrnrorsmsg)rformatjoinitemsrrrdetailsrnrnro__str__s  z Error.__str__cCs8|d}ddd|D}d|jjd|dS)N)rrrsecondsrrcSrrrnrrnrnrorrz"Error.__repr__..zpsutil.())rrr __class__rkrrnrnro__repr__s zError.__repr__N)rkrlrm__doc__rrrrnrnrnrors  rc@&eZdZdZdZdddZddZdS) NoSuchProcesszXException raised when a process with a certain PID doesn't or no longer exists. rNcC$t|||_||_|pd|_dS)Nzprocess no longer existsr__init__rrrrrrrrnrnror zNoSuchProcess.__init__cC|j|j|j|jffSNrrrrrrnrnro __reduce__zNoSuchProcess.__reduce__NNrkrlrmrrrrnrnrnrors   rc@r) 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. rNcCs$t||||||_|pd|_dS)Nz"PID still exists but it's a zombie)rrrr)rrrrrrnrnrorszZombieProcess.__init__cCs|j|j|j|j|jffSr)rrrrrrrnrnrorszZombieProcess.__reduce__NNNrrnrnrnrors   rc@r) AccessDeniedz@Exception raised when permission to perform an action is denied.rNcCr)NrrrrnrnrorrzAccessDenied.__init__cCrrrrrnrnrorrzAccessDenied.__reduce__rrrnrnrnrors   rc@r) TimeoutExpiredzWRaised on Process.wait(timeout) if timeout expires and process is still alive. rNcCs.t|||_||_||_d|d|_dS)Nztimeout after z seconds)rrrrrr)rrrrrnrnror s zTimeoutExpired.__init__cCrr)rrrrrrnrnrorrzTimeoutExpired.__reduce__rrrnrnrnrors   rcCs@z t||d}Wn tyYdSw|durt||}|S)z5Calculate percentage usage of 'used' against 'total'.dgN)floatZeroDivisionErrorround)usedtotalround_retrnrnror7s  r7cs2tfdd}fdd}i||_|S)aA 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() >>> It supports: - functions - classes (acts as a @singleton) - staticmethods - classmethods It does NOT support: - methods c sn|tt|f}z|WSty6z|i|}|<W|YSty5}z|dd}~wwwr) frozensetsortedrKeyError Exception)argskwargskeyrerrcachefunrnrowrapper?s  zmemoize..wrappercs dS)z Clear cache.N)clearrn)rrnro cache_clearK zmemoize..cache_clear) functoolswrapsr)rrrrnrror4's  r4cs6tfdd}dd}dd}||_||_|S)aA 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 sz|j}W|Sty&z|WYSty%}z|dd}~wwtyWz|}WntyA}z|dd}~wwz ||j<WY|StyVYY|Swwr)_cacheAttributeErrorrr)rrrrrnroros2     z'memoize_when_activated..wrappercSs i|_dS)zsActivate cache. Expects a Process instance. Cache will be stored as a "_cache" instance attribute. N)rprocrnrnrocache_activates z.memoize_when_activated..cache_activatecSs z|`WdStyYdSw)zDeactivate and clear cache.N)rrrrnrnrocache_deactivates   z0memoize_when_activated..cache_deactivate)rrrr)rrrrrnrromemoize_when_activatedTsrcCs>zt|}WntytyYdSwt|jS)zSame as os.path.isfile() but does not swallow EACCES / EPERM exceptions, see: http://mail.python.org/pipermail/python-dev/2012-June/120787.html. F)osstatPermissionErrorOSErrorS_ISREGst_mode)pathstrnrnror3s   r3cCs4zt|WdStytyYdSw)zSame as os.path.exists() but does not swallow EACCES / EPERM exceptions. See: http://mail.python.org/pipermail/python-dev/2012-June/120787.html. FT)rrrr)rrnrnror6s   r6cCsjtjrtdur dSz!tttj}|dWdWdS1s#wYWdSty4YdSw)z2Return True if IPv6 is supported on this platform.NF)z::1rT)sockethas_ipv6rrbindr)sockrnrnror8s   r8cCsxi}d}t} |d|}||kr |S|d||}||kr7|||}||d|}|r3|}|||<|d}q)zCParse a C environ block of environment variables into a dictionary.rTrrj)rfindupper)datarposWINDOWS_next_pos equal_posrrrnrnror5s"   r5cC$zt|WSty|YSw)zConvert a numeric socket family value to an IntEnum member. If it's not a known member, return the numeric value itself. )r AddressFamily ValueErrornumrnrnror9   r9cCr)zConvert a numeric socket type value to an IntEnum member. If it's not a known member, return the numeric value itself. )r SocketKindrrrnrnror:rr:c Csddlm}|tjthvr|r|j|}|r|j|}|tjkr-|tthvr-||t}nt}t |}t |}|durE| ||||||S| |||||||S)z2Convert a raw connection tuple to a proper ntuple.rj)_ntuplesN) rrrrraddrrgetrr9r:pconnsconn) fdfamtype_laddrraddrstatus status_maprntprnrnrorAs   rAcCsxddl}|jr |js dS|jtjkr#t|j|jd|jddjS|jtj kr:t|j |jd|jddjSdS)zbGiven the address ntuple returned by ``net_if_addrs()`` calculates the broadcast address. rN/F)strict) ipaddressaddressnetmaskfamilyrrstr IPv4Networkbroadcast_addressr IPv6Network)rrrnrnrobroadcast_addr s$   r csfdd}|S)zA decorator which can be used to mark a method as deprecated 'replcement' is the method name which will be called instead. cs>|jdd|jdur|_t|fdd}|S)Nz*() is deprecated and will be removed; use z () insteadcs$tjtddt||i|S)Nri)category stacklevel)warningswarnDeprecationWarningr)rrr)r replacementrnroinner-sz/deprecated_method..outer..inner)rkrrr)rrr)rroouter%s z deprecated_method..outerrn)rrrnrror2 s r2c@sBeZdZdZddZddZddZdd Zdd d Zd dZ d S) _WrapNumberszNWatches numbers so that they don't overflow and wrap (reset to zero). cCs t|_i|_i|_i|_dSr) threadingLocklockr reminders reminder_keysrrnrnror<s  z_WrapNumbers.__init__cCsX||jvsJ||jvsJ||jvsJ||j|<tt|j|<tt|j|<dSr)rrrr defaultdictintset)r input_dictrrnrnro _add_dictBs  z_WrapNumbers._add_dictcCs\|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)rrkeysrr)rr rold_dict gone_keysgone_keyremkeyrnrnro_remove_dead_remindersJs z#_WrapNumbers._remove_dead_remindersc Cs||jvr ||||S||||j|}i}|D]\}||}z||}Wn ty5|||<Yqwg}tt|D]3} || } || } || f} | | kre|j|| | 7<|j||| | | |j|| q>t |||<q||j|<|S)zlCache dict and sum numbers which overflow and wrap. Return an updated copy of `input_dict`. ) rr!r'rrangelenrraddappendtuple) rr rr#new_dictr input_tuple old_tuplebitsi input_value old_valuer&rnrnrorunUs4       z_WrapNumbers.runNcCs|j:|dur|j|j|jn|j|d|j|d|j|dWddSWddS1s@wYdS)z>Clear the internal cache, optionally only for function 'name'.N)rrrrrpop)rrrnrnror|s   "z_WrapNumbers.cache_clearcCs:|j|j|j|jfWdS1swYdS)z5Return internal cache dicts as a tuple of 3 elements.N)rrrrrrnrnro cache_infos$z_WrapNumbers.cache_infor) rkrlrmrrr!r'r4rr6rnrnrnror7s ' rcCs6tjt||WdS1swYdS)zGiven 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)_wnrr4)r rrnrnror;s $r;icCst|dtdS)Nrb) buffering)openFILE_READ_BUFFER_SIZE)fnamernrnror=r=cCsHt|tttd}zt|_W|StyY|Sty#|w)zaOpen a file in text mode by using the proper FS encoding and en/decoding error handlers. )r9encodingerrors)r:r;r/r0 _CHUNK_SIZErrclose)r<fobjrnrnror<s   r<cCs|tur|| }|WdS1swYdSz|| }|WdWS1s3wYWdStyE|YSw)zRead 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)_DEFAULTreadr)r<fallback_openfrnrnror>s $ ( r>cCst||tdS)z,Same as above but opens file in binary mode.)rErF)r>r=)r<rErnrnror?sr?%(value).1f%(symbol)scCsd}i}t|ddD]\}}d|dd>||<q t|ddD]}t|||kr>> bytes2human(10000) '9.8K' >>> bytes2human(100001221) '95.4M' ) BKMGTPEZYrjN r)symbolr) enumeratereversedabsrlocalsdict)nrsymbolsprefixr1srSrrnrnror@sr@cCs tjdjS)z+Return updated psutil.PROCFS_PATH constant.r)sysmodules PROCFS_PATHrnrnrnroget_procfs_pathrr`cCs|jttdS)N)r>r?)decoder/r0)r\rnrnrorar=racCs:t|dr |s dSz|WdStyYdSw)NisattyFT)hasattrrbfilenorfilernrnrorDs  rDFc Csts|Sg}tddddddddd d }d |d <z||}Wnty6d |dt|}t|d w|||rC|ddd|d|dS)z*Return an highlighted version of 'string'.343330323736913593) bluebrowndarkgreygreengrey lightblueredvioletyellow29Ninvalid color z; choose amongst 1z[;mz)rDrXrlistr"rr+r)r\colorboldattrcolorsrrnrnrorC s2      rCc Csts t||ddStrtt||||ddSddl}d}|jjj}|jjj}t ddddd}||d<z||}Wnt ySd |d t | } t | dw|r^|dkr^|d 7}|tjured nd } |j|_|| } || |zt||dW|| |dS|| |w)z$Print a colorized version of string.rerNri)rsrvrqrxrzz; choose between ii)rDprintrrCctypeswindllKernel32 GetStdHandleSetConsoleTextAttributerXrr~r"rr]stderrc_ulongrestype) r\rrrfr DEFAULT_COLORrrrr handle_idhandlernrnrorE%s:       rEcCsxtr:ddl}||j\}}}}}t|tr(t|tr#d|}nd|}td|d|d|t j ddSdS)z@If PSUTIL_DEBUG env var is set, print a debug message to stderr.rNz ignoring zpsutil-debug [:z]> re) rinspect getframeinfo currentframef_back isinstancerrrr]r)rrr<lineno__lines_indexrnrnrorBMs     rBr)rH)NF)mrrenumrrrrr]rrrrrr ImportErrorrboolgetenvrobjectrC__all__rrrplatform startswithr r rrr r r rAIXr%r&r"r'r)r-r!r+r,r#r$r*r(r.rrrrrrrrrrrrIntEnumrhglobalsupdate __members__rpgetfilesystemencodingr/getfilesystemencodeerrorsr0r1rrrrrrr7r4rr3r6r8r5r9r:rAr r2rr;r7rr6r;r=r<r>r?r@r`rastdoutrDrCrErBrnrnrnros      "                   !  -G  W       (