bib dZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddlm Z ddlm Z ddlm Z  ddlm Z  ddlmZeej"dZeZgd Zej,d k(Zej,d k(Zej2j5d Zej2j5d ZeZej2j5dZej2j5dZej2j5dZ exsexse Z!ej2j5dZ"ej2j5dZ#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+ZZOd?ZPd@ZQdAZRdBZSdCZTdDZUdEZVdFZWdZdGZXdHZYdIZZGdJdKZ[dLZ\e[Z]e]je\_^e]je\__dMZ`dNZadOZbeebfdPZcefdQZdd[dRZedSZfdTZgePejfdUZid\dWZjddVejfdXZkdYZly#e$rdZ Y&wxYw#e$rdZY-wxYw)]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)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_ACKLISTENCLOSINGNONEceZdZdZdZdZy) NicDuplexrN)__name__ __module__ __qualname__rr r!I/home/cdr/jupyterlab/.venv/lib/python3.12/site-packages/psutil/_common.pyrjrjzsOOrqrjceZdZdZdZy) BatteryTimeN)rmrnroPOWER_TIME_UNKNOWNPOWER_TIME_UNLIMITEDrprqrrrtrtsrqrt)alltcptcp4udpudp4inetinet4inet6)tcp6udp6unixc&eZdZdZdZdZdZdZy)ErrorzQBase exception class. All other psutil exceptions inherit from this one. psutilc|tj}|D]"}t||d}|s |dk(s|dk(s|||<$|S)Npidr) collections OrderedDictgetattr)selfattrsinfonamevalues rr _infodictzError._infodictsL&&( #DD$-E5A:"T  # rqc .|jd}|rGdjdj|jDcgc] \}}|d|c}}}nd}djt |dd|fDcgc]}|s| c}Scc}}wcc}w)N)rppidrz({}), = msg)rformatjoinitemsr)rrkvdetailsxs rr__str__z Error.__str__s~~56 mm DJJLADAqaS!<ABGGxxWT5"%=w$GMq1MNN BNsB 9BBc |jd}dj|jDcgc] \}}|d|c}}}d|jjd|dScc}}w)N)rrrsecondsrrrzpsutil.())rrr __class__rm)rrrrrs rr__repr__zError.__repr__sd~~GH))djjlCdas!A5\CD0017)1==DsA& N)rmrnro__doc__rrrrprqrrrrsJ O>rqrc"eZdZdZdZddZdZy) NoSuchProcesszXException raised when a process with a certain PID doesn't or no longer exists. rNc`tj|||_||_|xsd|_y)Nzprocess no longer existsr__init__rrrrrrrs rrrzNoSuchProcess.__init__s) t 44rqc`|j|j|j|jffSNrrrrrs rr __reduce__zNoSuchProcess.__reduce__$499dhh ?@@rqNNrmrnrorrrrprqrrrrsJ5 Arqrc"eZdZdZdZddZdZy) 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. rNcXtj||||||_|xsd|_y)Nz"PID still exists but it's a zombie)rrrr)rrrrrs rrrzZombieProcess.__init__s*tS$4 >>rqcv|j|j|j|j|jffSr)rrrrrrs rrrzZombieProcess.__reduce__s*499dii JKKrqNNNrrprqrrrrsJ? Lrqrc"eZdZdZdZddZdZy) AccessDeniedz@Exception raised when permission to perform an action is denied.rNc`tj|||_||_|xsd|_y)Nrrrs rrrzAccessDenied.__init__s' t 9"rqc`|j|j|j|jffSrrrs rrrzAccessDenied.__reduce__rrqrrrprqrrrrsJJ Arqrc"eZdZdZdZddZdZy)TimeoutExpiredzWRaised on Process.wait(timeout) if timeout expires and process is still alive. rNcntj|||_||_||_d|d|_y)Nztimeout after z seconds)rrrrrr)rrrrs rrrzTimeoutExpired.__init__ s3 t  #G9H5rqc`|j|j|j|jffSr)rrrrrs rrrzTimeoutExpired.__reduce__s$txx CDDrqrrrprqrrrrsJ6Erqrcd t||z dz}| t||}|S#t$rYywxYw)z5Calculate percentage usage of 'used' against 'total'.dg)floatroundZeroDivisionError)usedtotalround_rets rrr8r8sGT{U"c)  V$C s # //cbtjfd}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|jf} |S#t$r( |i|x}|<n#t$r}|dd}~wwxYw|cYSwxYwr) frozensetsortedrKeyError Exception)argskwargskeyrerrcachefuns rrwrapperzmemoize..wrapper?suYvflln567 :   $#&#7#77eCj $t# $J  s2, A AA A AAAAc&jy)z Clear cache.N)clear)rsrr cache_clearzmemoize..cache_clearKs  rq) functoolswrapsr)rrrrs` @rrr5r5's90__S   E%G Nrqcjtjfd}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}|S#t$r  |cYS#t$r}|dd}~wwxYwt$rC |}n#t$r}|dd}~wwxYw ||j<Y|S#t$rYY|SwxYwwxYwr)_cacheAttributeErrorrr)rrrrs rrrz'memoize_when_activated..wrapperos ++c"C( ' $ $4y  $t# $  $$i $t# $ #& C  "    se B(B 949 BA B AAAB#A55 B>BBBci|_y)zsActivate cache. Expects a Process instance. Cache will be stored as a "_cache" instance attribute. N)rprocs rrcache_activatez.memoize_when_activated..cache_activates  rqc( |`y#t$rYywxYw)zDeactivate and clear cache.N)rrrs rrcache_deactivatez0memoize_when_activated..cache_deactivates     s  )rrrr)rrrrs` rrmemoize_when_activatedrTsA6__S2 ,G/G Nrqc tj|}tj|jS#t$rt $rYywxYw)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)pathsts rrr4r4sH ( WWT] ||BJJ''  s6A  A c` tj|y#t$rt$rYywxYw)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)rrrr)rs rrr7r7s6     s --ctjrty tjttj5}|j ddddy#1swYyxYw#t $rYywxYw)z2Return True if IPv6 is supported on this platform.NF)z::1rT)sockethas_ipv6rrbindr)socks rrr9r9s_ ??h. ]]8V%7%7 8 "D IIj ! " " s/(A(AA(A%!A(%A(( A43A4ci}d}t} |jd|}||kr |S|jd||}||kDr$|||}||dz|}|r|j}|||<|dz}\)zCParse a C environ block of environment variables into a dictionary.rrrl)rfindupper)datarposWINDOWS_next_pos equal_posrrs rrr6r6s C CH 99T3' s?  JIIc31 s?s9%CQ2EiikCHl rqcP 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. )r AddressFamily ValueErrornums rrr:r:s,##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. )r SocketKindrrs rrr;r;s,  %%  rc ddlm}|tjthvr"|r|j |}|r|j |}|tj k(r%|tthvr|j|t}nt}t|}t|}||j||||||S|j|||||||S)z2Convert a raw connection tuple to a proper ntuple.rl)_ntuples) rr rrraddrrgetrr:r;pconnsconn) fdfamtype_laddrraddrstatus status_maprntps rrrBrBs! v~~x(( CHHe$E CHHe$E """sw.A'A 2 # C U #E {yyS%v>>yyS%vsCCrqcddl}|jr |jsy|jtj k(r?t |j|jd|jdjS|jtjk(r?t |j|jd|jdjSy)zbGiven the address ntuple returned by ``net_if_addrs()`` calculates the broadcast address. rN/F)strict) ipaddressaddressnetmaskfamilyrrstr IPv4Networkbroadcast_addressr IPv6Network)r rs rrbroadcast_addrr" s <.outer..inner-s- MM#(:q I-74-t>v> >rq)rmrrr)rr,rr+s @rrouterz deprecated_method..outer%sW||n}J (  ;; CK   ?  ? rqrp)r+r-s` rrr3r3 s  Lrqc6eZdZdZdZdZdZdZd dZdZ y) _WrapNumberszNWatches numbers so that they don't overflow and wrap (reset to zero). c`tj|_i|_i|_i|_yr) threadingLocklockr reminders reminder_keysrs rrrz_WrapNumbers.__init__<s&NN$  rqc||jvsJ||jvsJ||jvsJ||j|<tjt |j|<tjt |j|<yr)rr4r5r defaultdictintset)r input_dictrs rr _add_dictz_WrapNumbers._add_dictBs|4::%%%4>>)))4-----% 4*66s;t#.#:#:3#?4 rqc|j|}t|jt|jz }|D]9}|j||D]}|j||=|j||=;y)zIn case the number of keys changed between calls (e.g. a disk disappears) this removes the entry from self.reminders. N)rr9keysr5r4)rr:rold_dict gone_keysgone_keyremkeys rr_remove_dead_remindersz#_WrapNumbers._remove_dead_remindersJs::d# (3z/@+AA ! 3H,,T28< 1NN4(0 1""4(2 3rqc0||jvr|j|||S|j|||j|}i}|D]}||} ||}g}t t |D]t} || } || } || f} | | kr;|j || xx| z cc<|j||j| |j| |j || zvt|||<||j|<|S#t$r|||<YwxYw)zlCache dict and sum numbers which overflow and wrap. Return an updated copy of `input_dict`. ) rr;rBrrangelenr4r5addappendtuple) rr:rr>new_dictr input_tuple old_tuplebitsi input_value old_valuerAs rrrunz_WrapNumbers.runUsK tzz ! NN:t ,  ##J5::d# (C$S/K $SM D3{+, H)!n %aL q*NN4(0I=0&&t,S155f= K$..*>v*FFG H"$KHSM+ (.& 4) !,   sDDDNc|j5|O|jj|jj|jjnT|jj |d|jj |d|jj |ddddy#1swYyxYw)z>Clear the internal cache, optionally only for function 'name'.N)r3rrr4r5pop)rrs rrrz_WrapNumbers.cache_clear|s YY 3|   "$$&""((* tT*""4.""&&tT2 3 3 3s B&B<<Cc|j5|j|j|jfcdddS#1swYyxYw)z5Return internal cache dicts as a tuple of 3 elements.N)r3rr4r5rs rr cache_infoz_WrapNumbers.cache_infos: YY DJJ0B0BC D D Ds #:Ar) rmrnrorrr;rBrPrrTrprqrrr/r/7s( @ 3%N 3Drqr/cztj5tj||cdddS#1swYyxYw)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)_wnr3rP)r:rs rrr<r<s. )wwz4()))s1:ic&t|dtS)Nrb) buffering)openFILE_READ_BUFFER_SIZE)fnames rrr>r>s t'< ==rqct|ttt} t|_|S#t $rY|St $r|jwxYw)zaOpen a file in text mode by using the proper FS encoding and en/decoding error handlers. )rYencodingerrors)rZr[r0r1 _CHUNK_SIZErrclose)r\fobjs rrr=r=sa  '  D 1 K   K   s * AAc|tur"||5}|jcdddS ||5}|jcdddS#1swYyxYw#1swYyxYw#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)_DEFAULTreadr)r\fallback_openfs rrr?r?s| 8 5\ Q668   u vvx       O s9AA&A A&AA#A&#A&& A43A4c&t||tS)z,Same as above but opens file in binary mode.)rfrg)r?r>)r\rfs rrr@r@s ux{ ;;rqcd}i}t|ddD]\}}d|dzdzz||<t|ddD]3}t|||k\st|||z }|t zcS|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' ) BKMGTPEZYrlN r)symbolr) enumeratereversedabsrlocalsdict)nrsymbolsprefixrMsrurs rrrArAs 4 "$++-   s 0 <<Fc Dts|Sg}tddddddddd }d |d < ||}|j ||r|j dddj|d|dS#t$r,d |dt|j }t |d wxYw)z*Return an highlighted version of 'string'.343330323736913593) bluebrowndarkgreygreengrey lightblueredvioletyellow29Ninvalid color z; choose amongst 1z[;mz)rErzrlistr=rrGr)r~colorboldattrcolorsrs rrrDrD s  ! D     FF4L(u  KK  C 388D>"!A3g .. (ui'8fkkm9L8MNo4'(s A**5Bcttst||ytrtt||||yddl}d}|j j j}|j j j}tdddd}||d< ||}|r |dkr|d z }|tjurd nd } |j |_|| } || | t|||| |y#t$r,d |d t|j} t| dwxYw#|| |wxYw)z$Print a colorized version of string.rrNrk)rrrrrz; choose between ii)rEprintrrDctypeswindllKernel32 GetStdHandleSetConsoleTextAttributerzrrr=rrstderrc_ulongrestype) r~rrrr DEFAULT_COLORrrrr handle_idhandles rrrFrF%s: ! ad  fQt$40 }}--:: MM " " : : A1Aa8$t  ,5ME EQJ QJE3::-C3 %~~ i(. ; !$  #FM :! ,  *'*, S/t +  , $FM :sC4 D,45D), D7ctrddl}|j|jj\}}}}}t |t rt |trd|}nd|}td|d|d|tjyy)z@If PSUTIL_DEBUG env var is set, print a debug message to stderr.rNz ignoring zpsutil-debug [:z]> r) rinspect getframeinfo currentframef_back isinstancerrrrr)rrr\lineno__lines_indexs rrrCrCMs+2+?+?  " ) ), (vq&& c9 %#w'!#'!#) UG1VHCu 5CJJ rqr)z%(value).1f%(symbol)s)NF)mrrenumrrrrrr1r(rrrr ImportErrorrboolgetenvrobjectrd__all__rrrplatform startswithr rrr r r r rAIXr&r'r#r(r*r.r"r,r-r$r%r+r)r/rrrrrrrrrrrrIntEnumrjglobalsupdate __members__rtgetfilesystemencodingr0getfilesystemencodeerrorsr1r2rrrrrrr8r5rr4r7r9r6r:r;rBr"r3r/r<rVrrTr[r>r=r?r@rArrstdoutrErDrFrCrprqrrrsV     IBIIn-. 8 D 7 ''T/ ( )  ,, ! !"< = ,, ! !) ,   * ""F  45 lle$ $      !           &&'$,,  (() %3 $ $ &---/ h (; *C D h + /Y & h * .Y %x ; "; <i+z2 3j; 3 4    k]+j\*  u fy; *CDEF>I>BAEA"LML& A5 AEUE. *ZDN (  8D* ,.TDTDn)n?? .. ">4! ""< 5&- = !jj /:CJJ%;P gHGs#MM*M'&M'*M54M5