go dZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddlm Z ddlm Z ddlm Z ddlm Z  ddlmZn #e$rdZYnwxYw ddlmZn #e$rdZYnwxYweejd ZeZgd Zejd kZejd kZejd ZejdZeZejdZejdZ ejdZ!epe pe!Z"ejdZ#ejdZ$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+ZGd.d/ej?Z@eABe@jCGd0d1ej?ZDeABeDjCejEZFejGZHe d2gd3ZIe d4gd5ZJe d6gd7ZKe d8gd9ZLe d:gd;ZMe dgd?ZOe d@gdAZPe dBgdCZQe dDgdEZRe dFgdGZSe dHgdIZTe dJgdKZUe dLdMdNgZVe dOgdPZWe dQdRdSgZXe dTgdUZYe dVgdWZZe dXgdWZ[e dYgdZZ\e d[d\d]gZ]e d^d_d`gZ^e dagdbZ_e dcdddegZ`e eege e gfe ege gfe ge gfe ege gfe ge gfe ege e gfe ge e gfege e gfdfZae eaBege gfege gfdgee#seaBdhege e gfiGdidjebZcGdkdlecZdGdmdnedZeGdodpecZfGdqdrecZgddsZhdtZiduZjdvZkdwZleidxZmdyZndzZod{Zpdd|Zqd}Zrd~ZsGddZtdZuetZvevjweu_wevjxeu_xdZydZzdZ{ee{fdZ|efdZ}ddZ~dZdZeiejfdZddZddejfdZdZdS)zCommon 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) namedtuple)AF_INET) SOCK_DGRAM) SOCK_STREAM)AF_INET6)AF_UNIX PSUTIL_DEBUG)RFREEBSDBSDLINUXNETBSDOPENBSDMACOSOSXPOSIXSUNOSWINDOWS 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 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_ACKLISTENCLOSINGNONEceZdZdZdZdZdS) NicDuplexrN)__name__ __module__ __qualname__r r!r"D/granary/edev/quantum/lib/python3.11/site-packages/psutil/_common.pyr~r~s OOrr~ceZdZdZdZdS) BatteryTimeN)rrrPOWER_TIME_UNKNOWNPOWER_TIME_UNLIMITEDrrrrrsrrrD)totalusedfreepercentsinsoutr@)rrrrr>) read_count write_count read_bytes write_bytes read_time write_timer?)device mountpointfstypeoptsrA) bytes_sent bytes_recv packets_sent packets_recverrinerroutdropindropoutrE)nameterminalhoststartedpidr<)fdfamilytypeladdrraddrstatusrrB)raddressnetmask broadcastptprC)isupduplexspeedmtuflagsr=) ctx_switches interruptssoft_interruptssyscallsscpufreq)currentminmaxshwtemp)labelrhighcriticalsbattery)rsecsleft power_pluggedsfanrrr4)usersystem children_userchildren_systemr9pathrr:)id user_time system_timer;)real effectivesavedr6r7)rrrrr8ioclassvaluer5 voluntary involuntaryr3)rrrrrraddripport)alltcptcp4udpudp4inetinet4inet6)tcp6udp6unixc(eZdZdZdZdZdZdZdS)ErrorzQBase exception class. All other psutil exceptions inherit from this one. psutilc~tj}|D]&}t||d}|s |dkr |dkr|||<'|S)Nrr) collections OrderedDictgetattr)selfattrsinforrs r _infodictzError._infodict sW&(( # #DD$--E #5A::"T  rc|d}|rEddd|D}nd}ddt |dd|fDS) N)rppidrz({}), c"g|] \}}|d| S=r.0kvs r z!Error.__str__..s&AAADAqa<.sMMMq1MMMMrmsg)rformatjoinitemsrrrdetailss r__str__z Error.__str__s~~566  mm AADJJLLAAABBGGGxxMMWT5"%=%=w$GMMMNNNrc|d}dd|D}d|jjd|dS)N)rrrsecondsrrc"g|] \}}|d| Srrrs rrz"Error.__repr__.."s&CCCda\\A\\CCCrzpsutil.())rrr __class__rrs r__repr__zError.__repr__sZ~~GHH))CCdjjllCCCDD=0==7====rN)rrr__doc__rrr rrrrrsUJ O O O>>>>>rrc$eZdZdZdZddZdZdS) NoSuchProcesszXException raised when a process with a certain PID doesn't or no longer exists. rNcht|||_||_|pd|_dS)Nzprocess no longer existsr__init__rrrrrrrs rrzNoSuchProcess.__init__-s3 t 44rc8|j|j|j|jffSNr rrrrs r __reduce__zNoSuchProcess.__reduce__349dh ?@@rNNrrrrrrrrrrr&sMJ5555 AAAAArrc$eZdZdZdZddZdZdS) 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. rNc`t||||||_|pd|_dS)Nz"PID still exists but it's a zombie)rrrr)rrrrrs rrzZombieProcess.__init__As4tS$444 >>rcD|j|j|j|j|jffSr)r rrrrrs rrzZombieProcess.__reduce__Fs 49di JKKrNNNrrrrrr7sMJ???? LLLLLrrc$eZdZdZdZddZdZdS) AccessDeniedz@Exception raised when permission to perform an action is denied.rNcht|||_||_|pd|_dS)Nrrrs rrzAccessDenied.__init__Os1 t 9"rc8|j|j|j|jffSrrrs rrzAccessDenied.__reduce__Urrr!rrrrr#r#JsGJJJ AAAAArr#c$eZdZdZdZddZdZdS)TimeoutExpiredzWRaised on Process.wait(timeout) if timeout expires and process is still alive. rNczt|||_||_||_d|d|_dS)Nztimeout after z seconds)rrrrrr)rrrrs rrzTimeoutExpired.__init__`s? t  5G555rc8|j|j|j|jffSr)r rrrrs rrzTimeoutExpired.__reduce__gstx CDDrrrrrrr'r'YsMJ6666EEEEErr'cx t||z dz}|t||}|S#t$rYdSwxYw)z5Calculate percentage usage of 'used' against 'total'.dNg)floatroundZeroDivisionError)rrround_rets rrLrLps\T{{U"c)  V$$C sss + 99cftjfd}fd}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|tt|f} |S#t$r) |i|x}|<n#t$r}|dd}~wwxYw|cYSwxYwr) frozensetsortedrKeyError Exception)argskwargskeyr0errcachefuns rwrapperzmemoize..wrappersYvfllnn55667 :     $#&3#7#7#77eCjj $ $ $t# $JJJ  s3; A. AA. A&A!!A&&A.-A.c0dS)z Clear cache.N)clear)r;sr cache_clearzmemoize..cache_clears r) functoolswrapsr@)r<r=r@r;s` @rrIrI|sf0_S       E%G Nrcntjfd}d}d}||_||_|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 |j}nz#t$r$ |cYS#t$r}|dd}~wwxYwt$rA |}n#t$r}|dd}~wwxYw ||j<n#t$rYnwxYwYnwxYw|Sr)_cacheAttributeErrorr6r5)rr0r:r<s rr=z'memoize_when_activated..wrappers +c"CC $ $ $ $s4yy    $ $ $t# $    $c$ii $ $ $t# $ #& C  !      sq  B )B ;6; B AB A&A!!A&&B* A54B5 B?BBBBci|_dS)zsActivate cache. Expects a Process instance. Cache will be stored as a "_cache" instance attribute. N)rEprocs rcache_activatez.memoize_when_activated..cache_activates rc. |`dS#t$rYdSwxYw)zDeactivate and clear cache.N)rErFrHs rcache_deactivatez0memoize_when_activated..cache_deactivates2      DD s  )rArBrJrL)r<r=rJrLs` rmemoize_when_activatedrMsh6_S2 ,G/G Nrc tj|}tj|jS#t$rt $rYdSwxYw)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)osstatS_ISREGst_modePermissionErrorOSError)rsts rrHrHsa ( WT]] |BJ'''  uus/AAcf tj|dS#t$rt$rYdSwxYw)zSame as os.path.exists() but does not swallow EACCES / EPERM exceptions. See: http://mail.python.org/pipermail/python-dev/2012-June/120787.html. TF)rOrPrSrT)rs rrKrKsT   t  uus 00ctjrtdS tjttj5}|ddddn #1swxYwYdS#t $rYdSwxYw)z2Return True if IPv6 is supported on this platform.NF)z::1rT)sockethas_ipv6rrbindrT)socks rrMrMs ?h.u ]8V%7 8 8 "D IIj ! ! ! " " " " " " " " " " " " " " "t uus4$A*A A*A!!A*$A!%A** A87A8ci}d}t} |d|}||krnU|d||}||kr2|||}||dz|}|r|}|||<|dz}r|S)zCParse a C environ block of environment variables into a dictionary.rTrr)rfindupper)datar0posWINDOWS_next_pos equal_posr9rs rrJrJs C CH99T3'' s?? IIc311 s??s9}%CQ12E "iikkCHl JrcP tj|S#t$r|cYSwxYw)zConvert a numeric socket family value to an IntEnum member. If it's not a known member, return the numeric value itself. )rX AddressFamily ValueErrornums rrNrN7s<#C(((    %%cP tj|S#t$r|cYSwxYw)zConvert a numeric socket type value to an IntEnum member. If it's not a known member, return the numeric value itself. )rX SocketKindrgrhs rrOrOAs< %%%  rjc p|tjthvr|r t|}|r t|}|tjkr,|tthvr||t }nt }t|}t|}|t||||||St|||||||S)z2Convert a raw connection tuple to a proper ntuple.) rXrrrrgetrrNrOr3r<)rfamtype_rrr status_maprs rrVrVKs v~x(((  !%LE  !%LE """sw.A'A'A 22 #  C U # #E {ReUE6:::ReUE63???rcbddl}|jr|jsdS|jtjkr8t ||jd|jdjS|jtj kr8t | |jd|jdjSdS)zbGiven the address ntuple returned by ``net_if_addrs()`` calculates the broadcast address. rN/F)strict) ipaddressrrrrXrstr IPv4Networkbroadcast_addressr IPv6Network)rrus rbroadcast_addrrz^s <t|t {fn$$  ! !<00$,00 "      {fo%%  ! !<00$,00 "     &%rcfd}|S)zA decorator which can be used to mark a method as deprecated 'replcement' is the method name which will be called instead. c|jdd|j|_tj|fd}|S)Nz*() is deprecated and will be removed; use z () insteadchtjtdt||i|S)Nr)category stacklevel)warningswarnDeprecationWarningr)rr7r8r replacements rinnerz/deprecated_method..outer..inners: M#(:q I I I I-74--t>v>> >r)rrrArB)r<rrrs @routerz deprecated_method..outerysu| ( ( ( ( (  ; CK    ? ? ? ? ?   ? rr)rrs` rrGrGts#      Lrc8eZdZdZdZdZdZdZd dZdZ dS) _WrapNumberszNWatches numbers so that they don't overflow and wrap (reset to zero). c`tj|_i|_i|_i|_dSr) threadingLocklockr; reminders reminder_keysrs rrz_WrapNumbers.__init__s-N$$  rc||jvsJ||jvsJ||jvsJ||j|<tjt |j|<tjt |j|<dSr)r;rrr defaultdictintset)r input_dictrs r _add_dictz_WrapNumbers._add_dicts}4:%%%%4>))))4-----% 4*6s;;t#.#:3#?#?4   rc|j|}t|t|z }|D]4}|j||D]}|j||=|j||=5dS)zIn case the number of keys changed between calls (e.g. a disk disappears) this removes the entry from self.reminders. N)r;rkeysrr)rrrold_dict gone_keysgone_keyremkeys r_remove_dead_remindersz#_WrapNumbers._remove_dead_reminderss:d# ((3z/@/@+A+AA ! 3 3H,T28< 1 1N4(00"4(22 3 3rcl||jvr||||S||||j|}i}|D]}||} ||}n#t$r|||<Y%wxYwg}t t |D]} || } || } || f} | | krA|j|| xx| z cc<|j||| | | |j|| zt|||<||j|<|S)zlCache dict and sum numbers which overflow and wrap. Return an updated copy of `input_dict`. ) r;rrr5rangelenrraddappendtuple) rrrrnew_dictr9 input_tuple old_tuplebitsi input_value old_valuers rrunz_WrapNumbers.runs tz ! ! NN:t , , ,  ##J555:d# ( (C$S/K $SM    !,    D3{++,, H H)!n %aL q**N4(000I=000&t,S155f=== K$.*>v*FFGGGG!$KKHSMM% 4sAA/.A/Nc|j5|L|j|j|jnQ|j|d|j|d|j|dddddS#1swxYwYdS)z>Clear the internal cache, optionally only for function 'name'.N)rr;r?rrpop)rrs rr@z_WrapNumbers.cache_clears Y 3 3|   """$$&&&"((**** tT***""4..."&&tT222 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3sB B55B9<B9cl|j5|j|j|jfcdddS#1swxYwYdS)z5Return internal cache dicts as a tuple of 3 elements.N)rr;rrrs r cache_infoz_WrapNumbers.cache_infos Y D DJ0BC D D D D D D D D D D D D D D D D D Ds )--r) rrrrrrrrr@rrrrrrs   @@@ 3 3 3%%%N 3 3 3 3DDDDDrrctj5t||cdddS#1swxYwYdS)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)_wnrr)rrs rrPrPs ))wwz4(())))))))))))))))))s 599ic0t|dtS)Nrb) buffering)openFILE_READ_BUFFER_SIZE)fnames rrRrRs t'< = = ==rct|ttt} t|_n.#t $rYn"t $r|wxYw|S)zaOpen a file in text mode by using the proper FS encoding and en/decoding error handlers. )rencodingerrors)rrr1r2 _CHUNK_SIZErFr6close)rfobjs rrQrQs  '    D 1         Ks 1 AAc|tur9||5}|cdddS#1swxYwYdS ||5}|cdddS#1swxYwYdS#t$r|cYSwxYw)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)_DEFAULTreadrT)rfallback_openfs rrSrSs, 8 U5\\ Q6688                   u vvxx                     OOO sB6:: A=A0# A=0A44A=7A48A== B  B c0t||tS)z,Same as above but opens file in binary mode.)rr)rSrR)rrs rrTrT,s ux{ ; ; ;;r%(value).1f%(symbol)scPd}i}t|ddD]\}}d|dzdzz||<t|ddD]F}t|||kr+t|||z }|t zcSG|t |d|zS)zUsed by various scripts. See: https://code.activestate.com/recipes/578019-bytes-to-human-human-to-bytes-converter/?in=user-4178764. >>> bytes2human(10000) '9.8K' >>> bytes2human(100001221) '95.4M' ) BKMGTPEZYrN r)symbolr) enumeratereversedabsr,localsdict)nrsymbolsprefixrsrrs rrUrU1s> . .A . . ..s :AA<ctst||dStr"tt||||dSddl}d}|jjj}|jjj}tdddd}||d< ||}nE#t$r8d |d t| } t| dwxYw|r |dkr|d z }|tjurd nd } |j|_|| } || | t|||| |dS#|| |wxYw)z$Print a colorized version of string.rrNr)rrrrrz; choose between ii)rYprintrrXctypeswindllKernel32 GetStdHandleSetConsoleTextAttributerr5rrrgrstderrc_ulongrestype) rrrrr  DEFAULT_COLORr r rr handle_idhandles rrZrZ~s ! !!; ad ; fQt$$4000000  }-: M " : A1Aa888$t  ,5MEE , , ,,,,'',, S//t +  ,  EQJJ QJE3:--CC3 %~ i((... ; !$     # #FM : : : : : # #FM : : : :s BACD<<E c6trddl}||j\}}}}}t |t r t |trd|}nd|}td|d|d|tj dSdS)z@If PSUTIL_DEBUG env var is set, print a debug message to stderr.rNz ignoring zpsutil-debug [:z]> r) r inspect getframeinfo currentframef_back isinstancer6rTrrr)rrrlineno__lines_indexs rrWrWs +2+?+?  " " ), , (vq&& c9 % % *#w'' *'#'')#)) 5U 5 5V 5 5 5 5CJ        rr)r)NF)rrenumrArOrXrPrrrrrrrr ImportErrorrboolgetenvr objectr__all__rrrplatform startswithr rrr rr r rAIXr'r(r$r)r+r/r#r-r.r%r&r,r*r0rrrrrrrrrrrrIntEnumr~globalsupdate __members__rgetfilesystemencodingr1getfilesystemencodeerrorsr2rDr@r>r?rArEr<rBrCr=rrrrr4r9r:r;r6r7r8r5r3rrFr6rrrr#r'rLrIrMrHrKrMrJrNrOrVrzrGrrPrr@rrrRrQrSrTrUrrstdoutrYrXrZrWrrrr/s4     """"""HHHGGGtIBIn--.. 688   L 7 'T/ (( ))  , ! !"< = = , ! !) , ,   * * ""F  455 le$$ $      !           &'''$,  ())) %3 $ & &--//   7%%% & &Z &J&J&J K K *Y!<!<!< = = J{$N$N$N O O H444 5 5  7JJJKK 7... / / :jJJJ L L J{BBB D D  JNNN P P  :j";";"; < < * 777 9 9 :j"J"J"J K Kz&7I.// JGGG    J{VTN 3 3 *Y B B B C C 7:::;; 7:::;;j E E E *YG 4 5 5 H{M: ; ;  A A A   z&4.))h (; *C D h + /Y & h * .Y %x ; "; <i+z2 3j; 3 4     k]+j\*  u fy; *CDEFFF>>>>>I>>>BAAAAAEAAA"LLLLLMLLL& A A A A A5 A A AEEEEEUEEE.    ***ZDDDN ( ( (        8@@@@&   ,.TDTDTDTDTDTDTDTDn)))lnn? . ">>>4! ""<<<< 5555&--- === !j     ////:CJ%;%;%;%;P     s$AAAAA&%A&