Xho  dZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddlm Z ddlm Z ddlm Z ddlm Z  ddlmZ ddlmZeej$d ZeZgd Zej.d k(Zej.d k(Zej4j7d Zej4j7dZeZej4j7dZej4j7dZ ej4j7dZ!exse xse!Z"ej4j7dZ#ej4j7dZ$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@eAje@jGd0d1ej~ZDeAjeDjejZFejZHe 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 gfdfZaeeajege gfege gfdgee#seajdhege e gfiGdidjebZcGdkdlecZdGdmdnedZeGdodpecZfGdqdrecZgddsZhdtZiduZjdvZkdwZleidxZmdyZndzZod{Zpdd|Zqd}Zrd~ZsGddZtdZuetZvevjeu_wevjeu_xdZydZzdZ{ee{fdZ|efdZ}ddZ~dZdZeiejfdZddZddejfdZdZy#e$rdZY5wxYw#e$rdZY) 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&eZdZdZdZdZdZdZy)ErrorzQBase exception class. All other psutil exceptions inherit from this one. psutilc|tj}|D]"}t||d}|s |dk(s|dk(s|||<$|S)Nrr) collections OrderedDictgetattr)selfattrsinforrs r _infodictzError._infodict sL&&( #DD$-E5A:"T  # rc .|jd}|rGdjdj|jDcgc] \}}|d|c}}}nd}djt |dd|fDcgc]}|s| c}Scc}}wcc}w)N)rppidrz({}), = msg)rformatjoinitemsr)rrkvdetailsxs r__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__r)rrrrrs r__repr__zError.__repr__sd~~GH))djjlCdas!A5\CD0017)1==DsA& N)rrr__doc__rrrrrrrrsJ O>rrc"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 rr zNoSuchProcess.__init__-s) t 44rc`|j|j|j|jffSNrrrrrs r __reduce__zNoSuchProcess.__reduce__3$499dhh ?@@rNNrrrrr rrrrrr&sJ5 Arrc"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)rr rr)rrrrrs rr zZombieProcess.__init__As*tS$4 >>rcv|j|j|j|j|jffSr)rrrrrrs rrzZombieProcess.__reduce__Fs*499dii JKKrNNNrrrrrr7sJ? Lrrc"eZdZdZdZddZdZy) AccessDeniedz@Exception raised when permission to perform an action is denied.rNc`tj|||_||_|xsd|_y)Nrr r s rr zAccessDenied.__init__Os' t 9"rc`|j|j|j|jffSrrrs rrzAccessDenied.__reduce__UrrrrrrrrrJsJJ Arrc"eZdZdZdZddZdZy)TimeoutExpiredzWRaised on Process.wait(timeout) if timeout expires and process is still alive. rNcntj|||_||_||_d|d|_y)Nztimeout after z seconds)rr rrrr)rrrrs rr zTimeoutExpired.__init__`s3 t  #G9H5rc`|j|j|j|jffSr)rrrrrs rrzTimeoutExpired.__reduce__gs$txx CDDrrrrrrrrYsJ6Errcd t||z dz}| t||}|S#t$rYywxYw)z5Calculate percentage usage of 'used' against 'total'.dg)floatroundZeroDivisionError)rrround_rets rrLrLpsGT{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)argskwargskeyr(errcachefuns rwrapperzmemoize..wrappersuYvflln567 :   $#&#7#77eCj $t# $J  s2, A AA A AAAAc&jy)z Clear cache.N)clear)r3sr cache_clearzmemoize..cache_clears  r) functoolswrapsr8)r4r5r8r3s` @rrIrI|s90__S   E%G Nrcjtjfd}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)_cacheAttributeErrorr.r-)rr(r2r4s rr5z'memoize_when_activated..wrappers ++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)r=procs rcache_activatez.memoize_when_activated..cache_activates  rc( |`y#t$rYywxYw)zDeactivate and clear cache.N)r=r>r@s rcache_deactivatez0memoize_when_activated..cache_deactivates     s  )r9r:rBrD)r4r5rBrDs` rmemoize_when_activatedrEsA6__S2 ,G/G Nrc 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)rsts rrHrHsH ( 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)rGrHrKrL)rs rrKrKs6     s --ctjrty tjttj5}|j ddddy#1swYyxYw#t $rYywxYw)z2Return True if IPv6 is supported on this platform.NF)z::1rT)sockethas_ipv6rrbindrL)socks rrMrMsa ??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.rrr)rfindupper)datar(posWINDOWS_next_pos equal_posr1rs rrJrJs C CH 99T3' s?  JIIc31 s?s9%CQ2EiikCHl rcP 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. )rP 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. )rP SocketKindr_r`s rrOrOAs,  %%  rbc H|tjthvr|rt|}|rt|}|tjk(r%|tthvr|j |t }nt }t|}t|}|t||||||St|||||||S)z2Convert a raw connection tuple to a proper ntuple.) rPrrrrgetrrNrOr3r<)rfamtype_rrr status_maprs rrVrVKs v~~x(( %LE %LE """sw.A'A 2 # C U #E {ReUE6::ReUE63??rcddl}|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) ipaddressrrrrPrstr IPv4Networkbroadcast_addressr IPv6Network)rrms rbroadcast_addrrr^s <.outer..inners- MM#(:q I-74-t>v> >r)rrr9r:)r4r|rr{s @routerz deprecated_method..outerysW||n}J (  ;; CK   ?  ? rr)r{r}s` rrGrGts  Lrc6eZdZdZdZdZdZdZd dZdZ y) _WrapNumberszNWatches numbers so that they don't overflow and wrap (reset to zero). c`tj|_i|_i|_i|_yr) threadingLocklockr3 reminders reminder_keysrs rr z_WrapNumbers.__init__s&NN$  rc||jvsJ||jvsJ||jvsJ||j|<tjt |j|<tjt |j|<yr)r3rrr defaultdictintset)r input_dictrs r _add_dictz_WrapNumbers._add_dicts|4::%%%4>>)))4-----% 4*66s;t#.#:#:3#?4 rc|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)r3rkeysrr)rrrold_dict gone_keysgone_keyremkeys r_remove_dead_remindersz#_WrapNumbers._remove_dead_reminderss::d# (3z/@+AA ! 3H,,T28< 1NN4(0 1""4(2 3rc0||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`. ) r3rrr-rangelenrraddappendtuple) rrrrnew_dictr1 input_tuple old_tuplebitsi input_value old_valuers rrunz_WrapNumbers.runsK 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)rr3r7rrpop)rrs rr8z_WrapNumbers.cache_clears 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)rr3rrrs r cache_infoz_WrapNumbers.cache_infos: YY DJJ0B0BC D D Ds #:Ar) rrrrr rrrr8rrrrrrs( @ 3%N 3Drrcztj5tj||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)_wnrr)rrs rrPrPs. )wwz4()))s1:ic&t|dtS)Nrb) buffering)openFILE_READ_BUFFER_SIZE)fnames rrRrRs t'< ==rct|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. )rencodingerrors)rrr1r2 _CHUNK_SIZEr>r.close)rfobjs rrQrQsa  '  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)_DEFAULTreadrL)rfallback_openfs rrSrSs| 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.)rr)rSrR)rrs rrTrT,s ux{ ;;rcd}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' ) BKMGTPEZYrN r)symbolr) enumeratereversedabsr$localsdict)nrsymbolsprefixrsrrs rrUrU1s"!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.rrNr)rrrrrz; choose between ii)rYprintrrXctypeswindllKernel32 GetStdHandleSetConsoleTextAttributerr-rrr_rstderrc_ulongrestype) rrrrr DEFAULT_COLORrrrr handle_idhandles rrZrZ~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) r inspect getframeinfo currentframef_back isinstancer.rLrrr)rr rlineno__lines_indexs rrWrWs+2+?+?  " ) ), (vq&& c9 %#w'!#'!#) UG1VHCu 5CJJ rr)z%(value).1f%(symbol)s)NF)rrenumr9rGrPrHrrrxrrrrr 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;r6r7r8r5r3rrFr.rrrrrrLrIrErHrKrMrJrNrOrVrrrGrrPrr8rrrRrQrSrTrUrrstdoutrYrXrZrWrrrr&s    " IBIIn-. 8 L 7 ''T/ ( )  ,, ! !"< = ,, ! !) ,   * ""F  45 lle$ $      !           &&'$,,  (() %3 $ $ &---/  7% & &J K Y!< = {$N O H4 5 7JK7. / jJ L {B D  N P  j"; <  7 9 j"J K&7I./ G   {VTN 3 Y B C7:;7:; E YG 4 5 H{M: ; A  &4.)h (; *C D h + /Y & h * .Y %x ; "; <i+z2 3j; 3 4    k]+j\*  u fy; *CDEF>I>BAEA"LML& A5 AEUE. *ZDN (     8@& ,.TDTDn)n?? .. ">4! ""< 5&- = !jj   /:CJJ%;P UHGs$Q1Q?1Q<;Q<?R  R