o ZhMg @sdZddlmZddlmZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlmZddl mZddl mZddl mZzdd l mZWn eyadZYnwzdd l mZWn eyudZYnwe jd krddlZndZe jdd kZeed dZgdZejdkZejdkZe j dZ!e j dZ"e"Z#e j dZ$e j dZ%e j dZ&e$pe%pe&Z'e j dZ(e j dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1d Z2d!Z3d"Z4d#Z5d$Z6d%Z7d&Z8d'Z9d(Z:d)Z;d*Zd-Z?d.Z@d/ZAd0ZBd1ZCedurd2ZDd3ZEdZFnGd4d5d5ejGZHeIJeHjKedur+d6ZLd7ZMnGd8d9d9ejGZNeIJeNjKe OZPesEd:ZQnze RZQWneSy\erXd;nd:ZQYnwedgd?ZUed@gdAZVedBgdCZWedDgdEZXedFgdGZYedHgdIZZedJgdKZ[edLgdMZ\edNgdOZ]edPgdQZ^edRgdSZ_edTgdUZ`edVdWdXgZaedYgdZZbed[d\d]gZced^gd_Zded`gdaZeedbgdaZfedcgddZgededfdggZhedhdidjgZiedkgdlZjedmdndogZkeeegeegfeegegfegegfeegegfegegfeegeegfegeegfegeegfdpZledurNelJegegfegegfdqedur_elJdregeegfiGdsdtdtemZnGdudvdvenZoGdwdxdxeoZpGdydzdzenZqGd{d|d|enZrdd}d~ZsddZtddZuddZvddZwetddZxddZyddZzddZ{dddZ|ddZ}GdddZ~ddZe~Zeje_eje_ddZddZdddZddZerddZnddZete jfddZdddZdde jfddZddZdS)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)NFREEBSDBSDLINUXNETBSDOPENBSDMACOSOSXPOSIXSUNOSWINDOWS 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_ERRSrpconn pcputimespctxswpgidspiopionice popenfilepthreadpuidssconn scpustatssdiskio sdiskpart sdiskusagesnetiosnicaddr snicstatssswapsuser conn_tmapdeprecated_method isfile_strictmemoizeparse_environ_blockpath_exists_strict usage_percent supports_ipv6sockfam_to_enumsocktype_to_enum wrap_numbers bytes2humanconn_to_ntupledebughiliteterm_supports_colors print_colorposixntlinuxdarwin)freebsdZ midnightbsdopenbsdnetbsd)sunossolarisaixrunningsleepingz disk-sleepstoppedz tracing-stopzombieZdeadz wake-killZwakingZidlelockedZwaitingZ suspendedZparkedZ ESTABLISHEDZSYN_SENTZSYN_RECVZ FIN_WAIT1Z FIN_WAIT2Z TIME_WAITZCLOSEZ CLOSE_WAITZLAST_ACKZLISTENZCLOSINGNONEc@seZdZdZdZdZdS) NicDuplexrjrkrN)__name__ __module__ __qualname__r#r$r%rprpE/var/www/html/lang_env/lib/python3.10/site-packages/psutil/_common.pyrlsrlc@seZdZdZdZdS) BatteryTimerrrsN)rmrnroPOWER_TIME_UNKNOWNPOWER_TIME_UNLIMITEDrprprprqrtsrtreplacesurrogateescaperG)totalusedfreepercentsinZsoutrC)ryrzr{r|rA) read_count write_count read_bytes write_bytesZ read_timeZ write_timerB)ZdeviceZ mountpointZfstypeoptsZmaxfileZmaxpathrD)Z bytes_sentZ bytes_recvZ packets_sentZ packets_recvZerrinZerroutZdropinZdropoutrH)nameZterminalhoststartedpidr?)fdfamilytypeladdrraddrstatusrrE)raddressnetmask broadcastZptprF)ZisupZduplexspeedZmtur@)Z ctx_switchesZ interruptsZsoft_interruptsZsyscallsscpufreq)currentminmaxshwtemp)labelrhighcriticalsbattery)r|ZsecsleftZ power_pluggedsfanrrr7)usersystem children_userchildren_systemr<pathrr=)idZ user_timeZ system_timer>)realZ effectivesavedr9r:)r~rrrr;Zioclassvaluer8Z voluntaryZ involuntaryr6)rrrrrraddripport)allZtcpZtcp4ZudpZudp4ZinetZinet4Zinet6)Ztcp6Zudp6unixc@s,eZdZdZdZddZddZddZd S) ErrorzQBase exception class. All other psutil exceptions inherit from this one. psutilcCsJzt}Wn tyi}Ynw|D]}t||d}|r"|||<q|SN) collections OrderedDictAttributeErrorgetattr)selfattrsinforrrprprq _infodicts   zError._infodictcCsJ|d}|rdddd|D}nd}ddd|j|fDS)N)rppidrz(%s), cSg|] \}}d||fqSz%s=%rrp.0kvrprprq )z!Error.__str__.. cSsg|]}|r|qSrprp)rxrprprqr,s)rjoinitemsmsgrrdetailsrprprq__str__$s z Error.__str__cCs2|d}ddd|D}d|jj|fS)N)rrrsecondsrrcSrrrprrprprqr1rz"Error.__repr__..z psutil.%s(%s))rrr __class__rmrrprprq__repr__.s zError.__repr__N)rmrnro__doc__rrrrprprprqrs  rc@eZdZdZdZdddZdS) NoSuchProcesszXException raised when a process with a certain PID doesn't or no longer exists. rNcC$t|||_||_|pd|_dS)Nzprocess no longer existsr__init__rrrrrrrrprprqr; zNoSuchProcess.__init__NNrmrnrorrrprprprqr5rc@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)rrrrrrprprqrKszZombieProcess.__init__NNNrrprprprqrBsrc@r) AccessDeniedz@Exception raised when permission to perform an action is denied.rNcCr)NrrrprprqrUrzAccessDenied.__init__rrrprprprqrQsrc@r)TimeoutExpiredzWRaised on Process.wait(timeout) if timeout expires and process is still alive. rNcCs*t|||_||_||_d||_dS)Nztimeout after %s seconds)rrrrrr)rrrrrprprqrbs zTimeoutExpired.__init__rrrprprprqr\rrcCs@z t||d}Wn tyYdSw|durt||}|S)z5Calculate percentage usage of 'used' against 'total'.dgN)floatZeroDivisionErrorround)rzryZround_retrprprqrOos  rOcs2tfdd}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() >>> csL|tt|f}z|WSty%|i|}|<|YSwr) frozensetsortedrKeyError)argskwargskeyrcachefunrprqwrappers  zmemoize..wrappercs dS)z Clear cache.N)clearrp)rrprq cache_clear zmemoize..cache_clear) functoolswrapsr)rrrrprrqrL{s  rLcs6tfdd}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 sjz|j}W|Sty|YSty4|}z ||j<WY|Sty3YY|Swwr)_cacherr)rrrrprqrs    z'memoize_when_activated..wrappercSs i|_dS)zjActivate cache. Expects a Process instance. Cache will be stored as a "_cache" instance attribute.N)rprocrprprqcache_activates z.memoize_when_activated..cache_activatecSs z|`WdStyYdSw)zDeactivate and clear cache.N)rrrrprprqcache_deactivates   z0memoize_when_activated..cache_deactivate)rrrr)rrrrrprrqmemoize_when_activatedsrc CsVzt|}Wnty$}z|jtjtjfvrWYd}~dSd}~wwt|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 NF)osstatOSErrorerrnoEPERMEACCESS_ISREGst_mode)rsterrrprprqrKs rKc CsLzt|WdSty%}z|jtjtjfvrWYd}~dSd}~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)rrrrrr)rrrprprqrNs rNcCsvtjrtdur dSz&tttj}t||dWdWdS1s(wYWdStjy:YdSw)z2Return True if IPv6 is supported on this platform.NF)z::1rT)sockethas_ipv6rr contextlibclosingbinderror)sockrprprqrPs   rPcCsxi}d}t} |d|}||kr |S|d||}||kr7|||}||d|}|r3|}|||<|d}q)zCParse a C environ block of environment variables into a dictionary.rT=rk)rfindupper)datarposZWINDOWS_Znext_posZ equal_posrrrprprqrMs"   rMcC0tdur|Szt|WSty|YSw)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 ValueErrornumrprprqrQ"  rQcCr )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 SocketKindrrrprprqrR/rrRcCs|tjtfvr|r t|}|rt|}|tjkr%|ttfvr%||t}nt}t|}t|}|dur.outer..inner)rmrrr)rrr)rrqouterSs z deprecated_method..outerrp)rrrprrqrJOs  rJc@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_keysrrprprqrfs  z_WrapNumbers.__init__cCsX||jvsJ||jvsJ||jvsJ||j|<tt|j|<tt|j|<dSr)rr"r#r defaultdictintset)r input_dictrrprprq _add_dictls  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)rr'keysr#r")rr(rold_dictZ gone_keysZgone_keyremkeyrprprq_remove_dead_remindersts z#_WrapNumbers._remove_dead_remindersc Cs||jvr ||||S||||j|}i}|D]\}||}z||}Wn ty7|||<Yqwg}tt|D]3} || } || } || f} | | krg|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` ) rr)r-r*rrangelenr"r#addappendtuple) rr(rr+Znew_dictrZ input_tupleZ old_tuplebitsiZ input_value old_valuer,rprprqruns4        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)r!rrr"r#pop)rrrprprqrs   "z_WrapNumbers.cache_clearcCs:|j|j|j|jfWdS1swYdS)z5Return internal cache dicts as a tuple of 3 elements.N)r!rr"r#r$rprprq cache_infos$z_WrapNumbers.cache_infor) rmrnrorrr)r-r6rr8rprprprqras ' 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)_wnr!r6)r(rrprprqrSs $rScKst|dfi|S)Nrb)openfnamerrprprq open_binarysr>cKs.tr|dt|dtt|dfi|S)zOn 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'). encodingerrorsrt)PY3 setdefaultr4r5r;r<rprprq open_texts  rD%(value).1f%(symbol)scCsd}i}t|ddD]\}}d|dd>||<q t|ddD]}|||kr:t|||}|tSq#|t|d|dS)zUsed by various scripts. See: http://goo.gl/zeJZl >>> bytes2human(10000) '9.8K' >>> bytes2human(100001221) '95.4M' ) BKMGTPEZYrkN r)symbolr) enumeratereversedrlocalsdict)nformatsymbolsprefixr4srPrrprprqrTs  rTcCs tjdjS)z+Return updated psutil.PROCFS_PATH constant.r)sysmodulesZ PROCFS_PATHrprprprqget_procfs_pathrr\cCs|jttdS)N)r?r@)decoder4r5rYrprprqr]sr]cCs|Srrpr^rprprqr]scCsXtjdkrdSzddl}|sJ||ddksJWdSty+YdSw)Nr[TrcolorsF)rrcursesisattyZ setuptermZtigetnum Exception)filer`rprprqrXs   rXFc Csts|Sg}tddddddddd d }d |d <z||}Wnty/td t|w|||r<|ddd||fS)z*Return an highlighted version of 'string'.Z32Z91Z33Z93Z34Z35Z36Z37Z30) greenredbrownyellowbluevioletZ lightblueZgreyZdarkgreyZ29Nz#invalid color %r; choose between %s1z [%sm%s;)rXrTrrlistr*r1r)rYcolorboldattrr_rprprqrW s$      rWc Csts t||ddStrtt||||ddSddl}d}|jjj}|jjj}t ddddd}||d<z||}Wnt yNt d |t | fw|rY|dkrY|d 7}|tjur`d nd } |j|_|| } || |zt||dW|| |dS|| |w) z$Print a colorized version of string.rcrNrjr )rdrerfrgz#invalid color %r; choose between %rii)rXprintrrWctypesZwindllZKernel32 GetStdHandleSetConsoleTextAttributerTrrrlr*rZstderrZc_ulongrestype) rYrmrnrcruZ DEFAULT_COLORrvrwr_Z handle_idhandlerprprqrY s6      rYcCsrtr7ddl}||j\}}}}}t|tr)t|ttt fr%d|}nd|}t d|||ft j ddSdS)z@If PSUTIL_DEBUG env var is set, print a debug message to stderr.rNz ignoring %sz ignoring %rzpsutil-debug [%s:%s]> %srp) r inspect getframeinfo currentframef_back isinstancerbrIOErrorEnvironmentErrorrtrZrx)rr{r=lineno func_namelinesindexrprprqrVCs   rVr)rE)NF)r __future__rrrrrrrrrrZrrrrrrr ImportErrorr version_infor rBboolgetenvr __all__rrrplatform startswithrrrr rrrrZAIXr*r+r'r,r.r2r&r0r1r(r)r/r-r3rr!r rrr"rrrrrrr#r$r%IntEnumrlglobalsupdate __members__rurvrtgetfilesystemencodingr4r5getfilesystemencodeerrorsrrGrCrArBrDrHr?rErFr@rrrrr7r<r=r>r9r:r;r8r6rrIrbrrrrrrOrLrrKrNrPrMrQrRrUrJrrSr9rr8r>rDrTr\r]stdoutrXrWrYrVrprprprqs\           $                         "    ?   W      #