a QIho @sdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddlm Z ddlm Z ddlm Z ddlm Z zddlmZWneydZYn0zddlmZWneydZYn0eed ZeZgd Zejd kZejd kZejd ZejdZeZejdZejdZ ejdZ!epJe pJe!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/d/ej?Z@eABe@jCGd0d1d1ej?ZDeABeDjCeEZFeGZHe 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 gfdfZaedureaBege gfege gfdgedur&e#s&eaBdhege e gfiGdidjdjebZcGdkdldlecZdGdmdndnedZeGdodpdpecZfGdqdrdrecZgddsdtZhdudvZidwdxZjdydzZkd{d|Zleid}d~ZmddZnddZoddZpdddZqddZrddZsGdddZtddZuetZvevjweu_wevjxeu_xdZyddZzddZ{ee{fddZ|efddZ}dddZ~ddZddZeiejfddZdddZddejfddZddZdS)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)ZfreebsdZ midnightbsdZopenbsdZnetbsd)sunossolarisaixrunningsleepingz disk-sleepstoppedz tracing-stopzombieZdeadz wake-killZwakingidlelockedZwaitingZ suspendedZparkedZ ESTABLISHEDZSYN_SENTZSYN_RECVZ FIN_WAIT1Z FIN_WAIT2Z TIME_WAITZCLOSEZ CLOSE_WAITZLAST_ACKZLISTENZCLOSINGNONEc@seZdZdZdZdZdS) NicDuplexrN)__name__ __module__ __qualname__rr r!rnrnH/var/www/html/venv_bot_3.9/lib/python3.9/site-packages/psutil/_common.pyrhsrhc@seZdZdZdZdS) BatteryTimeN)rkrlrmZPOWER_TIME_UNKNOWNZPOWER_TIME_UNLIMITEDrnrnrnrorpsrprC)totalusedfreepercentsinZsoutr?)rsrtrurvr=) read_count write_count read_bytes write_bytesZ read_timeZ write_timer>)ZdeviceZ mountpointZfstypeoptsr@)Z bytes_sentZ bytes_recvZ packets_sentZ packets_recvZerrinZerroutZdropinZdropoutrD)nameZterminalhoststartedpidr;)fdfamilytypeladdrraddrstatusrrA)raddressnetmask broadcastZptprB)ZisupZduplexspeedZmtuflagsr<)Z ctx_switchesZ interruptsZsoft_interruptsZsyscallsscpufreq)currentminmaxshwtemp)labelrhighcriticalsbattery)rvZsecsleftZ power_pluggedsfanrrr3)usersystem children_userchildren_systemr8pathrr9)idZ user_timeZ system_timer:)realZ effectiveZsavedr5r6)rxryrzr{r7Zioclassvaluer4Z voluntaryZ involuntaryr2)rrrrrraddripport)allZtcpZtcp4ZudpZudp4ZinetZinet4Zinet6)Ztcp6Zudp6unixc@s,eZdZdZdZddZddZddZd S) ErrorzQBase exception class. All other psutil exceptions inherit from this one. psutilcCs>t}|D],}t||d}|s0|dkr |dkr |||<q |S)Nrr) collections OrderedDictgetattr)selfattrsinfor}rrnrnro _infodict s   zError._infodictcCsR|d}|r.dddd|D}nd}dddt|dd |fDS) N)rppidr}z({}), cSsg|]\}}|d|qS=rn.0kvrnrnro z!Error.__str__.. cSsg|] }|r|qSrnrn)rxrnrnrorrmsg)rformatjoinitemsrrrdetailsrnrnro__str__s z Error.__str__cCs8|d}ddd|D}d|jjd|dS)N)rrr}secondsrrcSsg|]\}}|d|qSrrnrrnrnror"rz"Error.__repr__..zpsutil.())rrr __class__rkrrnrnro__repr__s zError.__repr__N)rkrlrm__doc__rrrrnrnrnrors  rc@s&eZdZdZdZdddZddZdS) NoSuchProcesszXException raised when a process with a certain PID doesn't or no longer exists. rNcCs$t|||_||_|pd|_dS)Nzprocess no longer existsr__init__rr}rrrr}rrnrnror-s zNoSuchProcess.__init__cCs|j|j|j|jffSNrrr}rrrnrnro __reduce__3szNoSuchProcess.__reduce__)NNrkrlrmrrrrnrnrnror&s rc@s&eZdZdZdZdddZddZdS) 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)rrr}rrrnrnrorAszZombieProcess.__init__cCs|j|j|j|j|jffSr)rrr}rrrrnrnrorFszZombieProcess.__reduce__)NNNrrnrnrnror7s rc@s&eZdZdZdZdddZddZdS) AccessDeniedz@Exception raised when permission to perform an action is denied.rNcCs$t|||_||_|pd|_dS)NrrrrnrnrorOs zAccessDenied.__init__cCs|j|j|j|jffSrrrrnrnrorUszAccessDenied.__reduce__)NNNrrnrnrnrorJs rc@s&eZdZdZdZdddZddZdS) TimeoutExpiredzWRaised on Process.wait(timeout) if timeout expires and process is still alive. rNcCs.t|||_||_||_d|d|_dS)Nztimeout after z seconds)rrrrr}r)rrrr}rnrnror`s  zTimeoutExpired.__init__cCs|j|j|j|jffSr)rrrr}rrnrnrorgszTimeoutExpired.__reduce__)NNrrnrnrnrorYs rcCsDzt||d}Wnty(YdS0|dur>> @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 s|tt|f}z |WStyzz|i|}|<Wn*typ}z|dWYd}~n d}~00|YS0dSr) frozensetsortedrKeyError Exception)argskwargskeyrerrcachefunrnrowrappers  zmemoize..wrappercs dS)z Clear cache.N)clearrn)rrnro cache_clearszmemoize..cache_clear) functoolswrapsr)rrrrnrrorH|s  rHcs6tfdd}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 sz|j}WntyZz|WYStyT}z|dWYd}~n d}~00Ynltyz |}Wn*ty}z|dWYd}~n d}~00z||j<WntyYn0Yn0|Sr)_cacheAttributeErrorrr)rrrrrnrors"      z'memoize_when_activated..wrappercSs i|_dS)zsActivate cache. Expects a Process instance. Cache will be stored as a "_cache" instance attribute. N)rprocrnrnrocache_activatesz.memoize_when_activated..cache_activatecSs z|`WntyYn0dS)zDeactivate and clear cache.N)rrrrnrnrocache_deactivates z0memoize_when_activated..cache_deactivate)rrrr)rrrrrnrromemoize_when_activatedsrcCsFzt|}Wn&ty"Yn ty4YdS0t|jSdS)zSame as os.path.isfile() but does not swallow EACCES / EPERM exceptions, see: http://mail.python.org/pipermail/python-dev/2012-June/120787.html. FN)osstatPermissionErrorOSErrorS_ISREGst_mode)rstrnrnrorGs  rGcCs>zt|Wn&ty"Ynty4YdS0dSdS)zSame as os.path.exists() but does not swallow EACCES / EPERM exceptions. See: http://mail.python.org/pipermail/python-dev/2012-June/120787.html. FTN)rrrr)rrnrnrorJs  rJcCsjtjrtdurdSz>tttj}|dWdn1sB0YWdStydYdS0dS)z2Return True if IPv6 is supported on this platform.NF)z::1rT)sockethas_ipv6rrbindr)sockrnrnrorLs( rLcCsvi}d}t}|d|}||kr"qr|d||}||krh|||}||d|}|r`|}|||<|d}q |S)zCParse a C environ block of environment variables into a dictionary.rrrj)rfindupper)datarposZWINDOWS_Znext_posZ equal_posrrrnrnrorIs   rIcCs(z t|WSty"|YS0dS)zConvert a numeric socket family value to an IntEnum member. If it's not a known member, return the numeric value itself. N)r AddressFamily ValueErrornumrnrnrorM7s  rMcCs(z t|WSty"|YS0dS)zConvert a numeric socket type value to an IntEnum member. If it's not a known member, return the numeric value itself. N)r SocketKindrrrnrnrorNAs  rNcCs|tjthvr&|rt|}|r&t|}|tjkrJ|tthvrJ||t}nt}t|}t|}|durxt ||||||St |||||||SdS)z2Convert a raw connection tuple to a proper ntuple.N) rrrrrgetrrMrNr2r;)rfamtype_rrrZ status_maprrnrnrorUKsrUcCsxddl}|jr|jsdS|jtjkrFt|j|jd|jddjS|jtj krtt|j |jd|jddjSdS)zbGiven the address ntuple returned by ``net_if_addrs()`` calculates the broadcast address. rN/F)strict) ipaddressrrrrrstr IPv4Networkbroadcast_addressr IPv6Network)rr rnrnrobroadcast_addr^s   rcsfdd}|S)zA decorator which can be used to mark a method as deprecated 'replcement' is the method name which will be called instead. cs>|jdd|jdur"|_t|fdd}|S)Nz*() is deprecated and will be removed; use z () insteadcs$tjtddt||i|S)Nri)category stacklevel)warningswarnDeprecationWarningr)rrr)r replacementrnroinnersz/deprecated_method..outer..inner)rkrrr)rrr)rroouterys z deprecated_method..outerrn)rrrnrrorFts rFc@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_keysrrnrnrors z_WrapNumbers.__init__cCsX||jvsJ||jvsJ||jvs*J||j|<tt|j|<tt|j|<dSr)rrrr defaultdictintset)r input_dictr}rnrnro _add_dicts  z_WrapNumbers._add_dictcCs\|j|}t|t|}|D]0}|j||D]}|j||=q8|j||=q&dS)zIn case the number of keys changed between calls (e.g. a disk disappears) this removes the entry from self.reminders. N)rr keysrr)rr!r}old_dictZ gone_keysZgone_keyremkeyrnrnro_remove_dead_reminderss  z#_WrapNumbers._remove_dead_remindersc Cs||jvr||||S||||j|}i}|D]}||}z ||}Wntyn|||<Yq8Yn0g}tt|D]f} || } || } || f} | | kr|j|| | 7<|j||| | | |j|| qt |||<q8||j|<|S)zlCache dict and sum numbers which overflow and wrap. Return an updated copy of `input_dict`. ) rr"r&rrangelenrraddappendtuple) rr!r}r$Znew_dictrZ input_tupleZ old_tuplebitsiZ input_value old_valuer%rnrnroruns2        z_WrapNumbers.runNcCs||jb|dur0|j|j|jn*|j|d|j|d|j|dWdn1sn0YdS)z>Clear the internal cache, optionally only for function 'name'.N)rrrrrpop)rr}rnrnrors   z_WrapNumbers.cache_clearcCs:|j |j|j|jfWdS1s,0YdS)z5Return internal cache dicts as a tuple of 3 elements.N)rrrrrrnrnro cache_infosz_WrapNumbers.cache_info)N) rkrlrmrrr"r&r/rr1rnrnrnrors ' rcCs6tjt||WdS1s(0YdS)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/)r!r}rnrnrorOsrOicCst|dtdS)Nrb) buffering)openFILE_READ_BUFFER_SIZE)fnamernrnrorQsrQcCsLt|tttd}z t|_Wn,ty,YntyF|Yn0|S)zaOpen a file in text mode by using the proper FS encoding and en/decoding error handlers. )r4encodingerrors)r5r6r0r1 _CHUNK_SIZErrclose)r7ZfobjrnrnrorPs   rPcCs|tur:||}|WdS1s.0YnNz6||}|WdWS1sd0YWnty|YS0dS)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)r7fallback_openfrnrnrorRs ( , rRcCst||tdS)z,Same as above but opens file in binary mode.)r>r?)rRrQ)r7r>rnrnrorS,srS%(value).1f%(symbol)scCsd}i}t|ddD]\}}d|dd>||<qt|ddD]2}t|||krFt|||}|tSqF|t|d|dS)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' ) BKMGTPEZYrjN r)symbolr) enumeratereversedabsrlocalsdict)nrsymbolsprefixr-srLrrnrnrorT1srTcCs tjdjS)z+Return updated psutil.PROCFS_PATH constant.r)sysmodulesZ PROCFS_PATHrnrnrnroget_procfs_pathDsrXcCs|jttdS)N)r8r9)decoder0r1)rUrnrnrorYIsrYcCs^tjdkrdSz2ddl}|s$J||ddks>JWntyTYdS0dSdS)Nr[TrcolorsF)rr}cursesisattyZ setuptermZtigetnumr)filer[rnrnrorXRs   rXFc Csts |Sg}tddddddddd d }d |d <z ||}Wn4typd |dt|}t|d Yn0|||r|ddd|d|dS)z*Return an highlighted version of 'string'.Z34Z33Z30Z32Z37Z36Z91Z35Z93) bluebrownZdarkgreygreenZgreyZ lightblueredvioletyellowZ29Ninvalid color z; choose amongst 1z[;mz)rXrQrlistr#rr*r)rUcolorboldattrrZrrnrnrorWbs0     rWc Cstst||dntr.tt||||dnddl}d}|jjj}|jjj}t ddddd}||d<z ||}Wn4t yd |d t | } t | dYn0|r|dkr|d 7}|tjurd nd } |j|_|| } || |zt||dW|| |n || |0dS)z$Print a colorized version of string.r]rNri)r`rar_rcrdz; choose between ii)rXprintrrWctypesZwindllZKernel32 GetStdHandleSetConsoleTextAttributerQrrhr#rrVstderrZc_ulongrestype) rUrirjr]rrZ DEFAULT_COLORrsrtrZrZ handle_idhandlernrnrorY~s8      rYcCsttrpddl}||j\}}}}}t|trPt|trFd|}n d|}td|d|d|t j ddS)z@If PSUTIL_DEBUG env var is set, print a debug message to stderr.rNz ignoring zpsutil-debug [:z]> rl) rinspect getframeinfo currentframef_back isinstancerrrqrVru)rryr7lineno__lines_indexrnrnrorVs    rV)N)N)rA)NF)rrenumrrrrrVrrrrrrr ImportErrorrboolgetenvrobjectr<__all__r}rrplatform startswithr rrr r r r rZAIXr&r'r#r(r*r.r"r,r-r$r%r+r)r/rrrrrrrrrrrrIntEnumrhglobalsupdate __members__rpgetfilesystemencodingr0getfilesystemencodeerrorsr1rCr?r=r>r@rDr;rArBr<rrrrr3r8r9r:r5r6r7r4r2rrErrrrrrrKrHrrGrJrLrIrMrNrUrrFrrOr2rr1r6rQrPrRrSrTrXrYstdoutrXrWrYrVrnrnrnros<        &                    ! -G   W       (