g+t dZddlmZddlmZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlmZddl mZddl mZddl mZ dd l mZn #e$rdZYnwxYw dd l mZn #e$rdZYnwxYwe jdd kZerddlZndZeejd ZeZgd ZejdkZejdkZ e 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/dZ0dZ1dZ2dZ3dZ4d Z5d!Z6d"Z7d#Z8d$Z9d%Z:d&Z;d'Zd*Z?d+Z@d,ZAd-ZBd.ZCd/ZDd0ZEed1ZFd2ZGdZHn5Gd3d4ejIZJeKLeJjMed5ZNd6ZOn5Gd7d8ejIZPeKLePjMe jQZResd9ZSn" e jTZSn#eU$r erd:nd9ZSYnwxYwed;gd<ZVed=gd>ZWed?gd@ZXedAgdBZYedCgdDZZedEgdFZ[edGgdHZ\edIgdJZ]edKgdLZ^edMgdNZ_edOgdPZ`edQgdRZaedSgdTZbedUdVdWgZcedXgdYZdedZd[d\gZeed]gd^Zfed_gd`Zgedagd`ZhedbgdcZiedddedfgZjedgdhdigZkedjgdkZledldmdngZmeeegeegfeegegfegegfeegegfegegfeegeegfegeegfegeegfdoZne enLegegfegegfdpeenLdqegeegfiGdrdseoZpGdtduepZqGdvdweqZrGdxdyepZsGdzd{epZter-euevewr evd|Zxn eyevd|Zxexd}nd~ZzddZ{dZ|dZ}dZ~dZe|dZdZdZdZddZdZGddZdZeZeje_eje_dZdZdZeefdZefdZddZdZerdZndZe|e jfdZddZdde jfdZdZdS)z9Common objects shared by __init__.py and _ps*.py modules.)division)print_functionN) 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_ERRSr pconn 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) NicDuplexrrrN)__name__ __module__ __qualname__r#r$r%J/var/www/html/ai-engine/env/lib/python3.11/site-packages/psutil/_common.pyrrs rrceZdZdZdZdS) BatteryTimerrN)rrrPOWER_TIME_UNKNOWNPOWER_TIME_UNLIMITEDrrrrrs!rrreplacesurrogateescaperG)totalusedfreepercentsinsoutrC)rrrrrA) read_count write_count read_bytes write_bytes read_time write_timerB)device mountpointfstypeoptsrD) bytes_sent bytes_recv packets_sent packets_recverrinerroutdropindropoutrH)nameterminalhoststartedpidr?)fdfamilytypeladdrraddrstatusrrE)raddressnetmask broadcastptprF)isupduplexspeedmtuflagsr@) ctx_switches interruptssoft_interruptssyscallsscpufreq)currentminmaxshwtemp)labelrhighcriticalsbattery)rsecsleft power_pluggedsfanrrr7)usersystem children_userchildren_systemr<pathrr=)id user_time system_timer>)real effectivesavedr9r:)rrrrr;ioclassvaluer8 voluntary involuntaryr6)rrrrrraddripport)alltcptcp4udpudp4inetinet4inet6)tcp6udp6unixc(eZdZdZdZdZdZdZdS)ErrorzQBase exception class. All other psutil exceptions inherit from this one. psutilctj}|D],}t||d}|r|||<|dkr |dkr|||<-|S)Nrr) collections OrderedDictgetattr)selfattrsinforrs r _infodictzError._infodict$sc&(( # #DD$--E #"T 5A::"T  rc|d}|r5ddd|Dz}nd}ddt|dd|fDS) N)rppidrz(%s), c"g|] \}}|d| S=r.0kvs r z!Error.__str__..3s';;;daAAAqq!;;;r cg|]}||Srr)rxs rrz!Error.__str__..7sMMMq1MMMMrmsg)rjoinitemsrrrdetailss r__str__z Error.__str__.s~~566  tyy;;djjll;;;  GGGxxMMWT5"%=%=w$GMMMNNNrc|d}dd|D}d|jjd|dS)N)rrrsecondsrrc"g|] \}}|d| Srrrs rrz"Error.__repr__..<s'GGG$!Q11-GGGrzpsutil.())rrr __class__rrs r__repr__zError.__repr__9sX~~GHH))GG$**,,GGGHH"&."9"9"9777CCrN)rrr__doc__rr rrrrrrsZJ O O ODDDDDrrc$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__Gs3 t 44rc8|j|j|j|jffSNrrrrrs r __reduce__zNoSuchProcess.__reduce__M49dh ?@@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__[s4tS$444 >>rcD|j|j|j|j|jffSr)rrrrrrs rrzZombieProcess.__reduce__`s 49di JKKrNNNr rrrr"r"QsMJ???? LLLLLrr"c$eZdZdZdZddZdZdS) AccessDeniedz@Exception raised when permission to perform an action is denied.rNcht|||_||_|pd|_dS)Nrrrs rrzAccessDenied.__init__is1 t 9"rc8|j|j|j|jffSrrrs rrzAccessDenied.__reduce__orrr%r rrrr'r'dsGJJJ AAAAArr'c$eZdZdZdZddZdZdS)TimeoutExpiredzWRaised on Process.wait(timeout) if timeout expires and process is still alive. rNcxt|||_||_||_d|z|_dS)Nztimeout after %s seconds)rrr rrr)rr rrs rrzTimeoutExpired.__init__zs9 t  -7rc8|j|j|j|jffSr)rr rrrs rrzTimeoutExpired.__reduce__stx CDDrrr rrrr+r+ssMJ8888EEEEErr+execzvdef raise_from(value, from_value): try: raise value from from_value finally: value = None c|rr)r from_values r raise_fromr1s rcx t||z dz}|t||}|S#t$rYdSwxYw)z5Calculate percentage usage of 'used' against 'total'.dNg)floatroundZeroDivisionError)rrround_rets rrOrOs\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$r6 |i|x}|<n"#t$r}t |dd}~wwxYw|cYSwxYwr) frozensetsortedrKeyError Exceptionr1)argskwargskeyr8errcachefuns rwrapperzmemoize..wrappersYvfllnn55667 :     ,#&3#7#7#77eCjj , , , d+++ ,JJJ  s3; A; AA; A3A..A33A;:A;c0dS)z Clear cache.N)clear)rCsr cache_clearzmemoize..cache_clears r) functoolswrapsrH)rDrErHrCs` @rrLrLsf0_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() >>> cN |j}n#t$r1 |cYS#t$r}t|dd}~wwxYwt$rN |}n"#t$r}t|dd}~wwxYw ||j<n#t$rYnwxYwYnwxYw|Sr)_cacheAttributeErrorr>r1r=)rr8rBrDs rrEz'memoize_when_activated..wrappers  +c"CC , , , ,s4yy    , , , d+++ ,    ,c$ii , , , d+++ , #& C  !      sv  B" )B" AAA B" A! B"! B+A;;BB" BB" BB"BB"!B"ci|_dS)zsActivate cache. Expects a Process instance. Cache will be stored as a "_cache" instance attribute. N)rMprocs rcache_activatez.memoize_when_activated..cache_activate s rc. |`dS#t$rYdSwxYw)zDeactivate and clear cache.N)rMrNrPs rcache_deactivatez0memoize_when_activated..cache_deactivates2      DD s  )rIrJrRrT)rDrErRrTs` rmemoize_when_activatedrUsh6_S2 ,G/G Nrc tj|}tj|jS#t$r+}|jt jt jfvrYd}~dSd}~wwxYw)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)osstatS_ISREGst_modeOSErrorerrnoEPERMEACCES)rstrBs rrKrKso ( WT]] |BJ'''  9el3 3 3 uuuuus/ A$ AA$c tj|dS#t$r+}|jtjtjfvrYd}~dSd}~wwxYw)zSame as os.path.exists() but does not swallow EACCES / EPERM exceptions. See: http://mail.python.org/pipermail/python-dev/2012-June/120787.html. TNF)rWrXr[r\r]r^)rrBs rrNrN-sb   t  9el3 3 3 uuuuus A  AA c(tjrtdS tjttj}t j|5|ddddn #1swxYwYdS#tj$rYdSwxYw)z2Return True if IPv6 is supported on this platform.NF)z::1rT)sockethas_ipv6r r contextlibclosingbinderror)socks rrPrP<s ?h.u}Xv'9::   % % " " IIj ! ! ! " " " " " " " " " " " " " " "t <uus58A>A1% A>1A55A>8A59A>>BBci}d}t} |d|}||krnU|d||}||kr2|||}||dz|}|r|}|||<|dz}r|S)zCParse a C environ block of environment variables into a dictionary.rTrr)rfindupper)datar8posWINDOWS_next_pos equal_posrArs rrMrMJs C CH99T3'' s?? IIc311 s??s9}%CQ12E "iikkCHl Jrcbt|S 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. )enumrb AddressFamily ValueErrornums rrQrQfsH |  ',, ,   JJJ   ..cbt|S 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. )rsrb SocketKindrurvs rrRrRssH |  $S)) )   JJJ rxc p|tjtfvr|r t|}|r t|}|tjkr,|ttfvr||t }nt }t|}t|}|t||||||St|||||||S)z2Convert a raw connection tuple to a proper ntuple.) rbrr rrgetrrQrRr6r?)rfamtype_rrr status_maprs rrYrYs v~x(((  !%LE  !%LE """sw.A'A'A 22 #  C U # #E {ReUE6:::ReUE63???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)rr?r@r replacements rinnerz/deprecated_method..outer..inners: M#(:q I I I I-74--t>v>> >r)rrrIrJ)rDrrrs @routerz deprecated_method..outersf LLL KK  ; CK    ? ? ? ? ?   ? rr)rrs` rrJrJs#      Lrc8eZdZdZdZdZdZdZd dZdZ dS) _WrapNumberszNWatches numbers so that they don't overflow and wrap (reset to zero). c`tj|_i|_i|_i|_dSr) threadingLocklockrC reminders reminder_keysrs rrz_WrapNumbers.__init__s-N$$  rc||jvsJ||jvsJ||jvsJ||j|<tjt |j|<tjt |j|<dSr)rCrrr 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)rCrkeysrr)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`. ) rCrrr=rangelenrraddappendtuple) rrrrnew_dictrA 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)rrCrGrrpop)rrs rrHz_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)rrCrrrs 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) rrrrrrrrrHrrrrrrs   @@@ 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 rrSrSs ))wwz4(())))))))))))))))))s 599ic0t|dtS)Nrb buffering)openFILE_READ_BUFFER_SIZE)fnames rrUrUs t'< = = ==rctst|tSt|ttt} t|_n.#t $rYn"t$r|wxYw|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'). r)rencodingerrors) PY3rrr4r5 _CHUNK_SIZErNr>close)rfobjs rrTrT"s <E%:;;;;  '    D 1         Ks A A9A9c,|tur9||5}|cdddS#1swxYwYdS ||5}|cdddS#1swxYwYdS#ttf$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)_DEFAULTreadIOErrorr[)rfallback_openfs rrVrV@s1 8 U5\\ Q6688                   u vvxx                  !   OOO sB6:: A=A0# A=0A44A=7A48A==BBc0t||tS)z,Same as above but opens file in binary mode.)rr)rVrU)rrs rrWrWQs 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: http://goo.gl/zeJZl. >>> bytes2human(10000) '9.8K' >>> bytes2human(100001221) '95.4M' ) BKMGTPEZYrN r)symbolr) enumeratereversedabsr4localsdict)nformatsymbolsprefixrsrrs rrXrXVs)filers rr\r\~s w$t  {{}}x((1,,,,,t uusA A A.-A.Fc ts|Sg}tddddddddd }d |d < ||}n?#t$r2td t |zwxYw|||r|ddd|d|dS)z*Return an highlighted version of 'string'.343330323736913593) bluebrowndarkgreygreengrey lightblueredvioletyellow29Nz#invalid color %r; choose between %s1z[;mz)r\rr=rulistrrr)rcolorboldattrrs rr[r[s  ! ! D       FF4L u      1T&++--5H5H I     KK  C"%((4....!!! 44s : r ) r inspect getframeinfo currentframef_back isinstancer>r[rEnvironmentErrorrrr)rr rlineno__lines_indexs rrZrZs +2+?+?  " " ), , (vq&& c9 % % *#2BCDD *#c)#c) */%% =CJ        rr)r)NF)r __future__rrrrdr\rIrWrbrXrrrrrrrr ImportErrorr version_inforrsboolgetenvr objectr__all__rrrplatform startswithrrrr rrrrAIXr*r+r'r,r.r2r&r0r1r(r)r/r-r3rr!r rrr"rrrrrrr#r$r%IntEnumrglobalsupdate __members__rrrgetfilesystemencodingr4r5getfilesystemencodeerrorsrNrGrCrArBrDrHr?rErFr@rrrrr7r<r=r>r9r:r;r8r6rrIr>rrr"r'r+r$ __builtins__rexec_rr1rOrLrUrKrNrPrMrQrRrYrJrrSrrHrrrUrTrVrWrXrrstdoutr\r[r]rZrrrr=s  @?  %%%%%%  """"""HHHGGG  qQKKKK DtIBIn--.. 688   L 7 'T/ (( ))  , ! !"< = = , ! !) , ,   * * ""F  455 le$$ $      !        <OODL  GIIY*+++<"""""dl""" GII[,--- %3 $ & & BMMB5577 BBB-2A)) B  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\*   fy; *CDEFFF D D D D DI D D DFAAAAAEAAA"LLLLLMLLL& A A A A A5 A A AEEEEEUEEE2z,%%.V$ f-- E         ***ZDDDN ( ( (        8      @@@@&.TDTDTDTDTDTDTDTDn)))lnn? . ">>><! ""<<<< 5555&--- AAAA  !j     5555<CJ$;$;$;$;N     s6AA! A!%A,,A65A6I!! I/.I/