Cs[)F X @ s d Z d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l
Z
d d l Z d d l m
Z
d d l m Z d d l m Z d d l m Z d d l m Z y d d l m Z Wn e k
r d Z Yn Xy d d
l m Z Wn e k
r/d Z Yn Xe j d k rNd d l Z n d Z e j d d k Z d
d d d d d d d d d d d d d d d d d d d d! d" d# d$ d% d& d' d( d) d* d+ d, d- d. d/ d0 d1 d2 d3 d4 d5 d6 d7 d8 d9 d: d; d< d= d> d? d@ dA dB dC dD dE dF dG dH dI dJ dK dL dM dN dO dP dQ dR dS dT gH Z e j dU k Z e j dV k Z e j j dW Z e j j dX Z e Z e j j dY Z! e j j dZ Z" e j j d[ Z# e! pe" pe# Z$ e j j d Z% e j j d^ Z& d_ Z' d` Z( da Z) db Z* dc Z+ dd Z, de Z- df Z. dg Z/ dh Z0 di Z1 dj Z2 dk Z3 dl Z4 dm Z5 dn Z6 do Z7 dp Z8 dq Z9 dr Z: ds Z; dt Z< du Z= dv Z> dw Z? dx Z@ e d k rdy ZA dz ZB d ZC n, Gd{ d| d| e jD ZE eF jG eE jH e d k rd ZI d ZJ n, Gd} d~ d~ e jD ZK eF jG eK jH e jL ZM e sDd ZN n7 y e jO ZN Wn$ eP k
rze rpd n d ZN Yn Xe dH d d d d d d g ZQ e dD d d d d g ZR e dB d d d d d d g ZS e dC d d d d g ZT e dE d d d d d d d d g ZU e dI d d d d d g ZV e d@ d d d d d d d g ZW e dF d d d d d g ZX e dG d d d d g ZY e dA d d d d g ZZ e d d d d g Z[ e d d d d d g Z\ e d d d d g Z] e d d d g Z^ e d8 d d d d g Z_ e d= d d g Z` e d> d d d g Za e d? d d d g Zb e d: d d d g Zc e d; d d d d g Zd e d< d d g Ze e d9 d d g Zf e d7 d d d d d d g Zg e d d d g Zh d e e e g e e g f d e e g e g f d e g e g f d e e g e g f d e g e g f d e e g e e g f d e g e e g f d e g e e g f i Zi e d k rei jG d e g e g f d e g e g f i e d k r ei jG d e g e e g f i [ [ [ [ d d dP Zj d dM Zk d d Zl d dL Zm d dO Zn ek d dQ Zo d dN Zp d dR Zq d dS Zr d dK Zs Gd d d Zt d dT Zu et Zv ev jw eu _w ev jx eu _x d S)z9Common objects shared by __init__.py and _ps*.py modules. )divisionN) defaultdict)
namedtuple)AF_INET)
SOCK_DGRAM) SOCK_STREAM)AF_INET6)AF_UNIX FREEBSDBSDLINUXNETBSDOPENBSDMACOSOSXPOSIXSUNOSWINDOWSENCODING
ENCODING_ERRSr
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_PARKEDpconn pcputimespctxswpgidspiopionice popenfilepthreadpuidssconn scpustatssdiskio sdiskpart
sdiskusagesnetiosnicaddr snicstatssswapsuser conn_tmapdeprecated_method
isfile_strictmemoizeparse_environ_blockpath_exists_strict
usage_percent
supports_ipv6sockfam_to_enumsocktype_to_enum wrap_numbersposixntlinuxdarwinZfreebsdZopenbsdZnetbsdsunossolarisaixrunningZsleepingz
disk-sleepstoppedz tracing-stopZzombieZdeadz wake-killZwakingZidlelockedZwaitingZ suspendedZparkedZ ESTABLISHEDZSYN_SENTZSYN_RECVZ FIN_WAIT1Z FIN_WAIT2Z TIME_WAITZCLOSEZ
CLOSE_WAITZLAST_ACKZLISTENZCLOSINGNONE c @ s" e Z d Z d Z d Z d Z d S) NicDuplexr^ r_ r N)__name__
__module__ __qualname__r$ r% r& rd rd /_common.pyr` s r` c @ s e Z d Z d Z d Z d S) BatteryTimer_ r^ N)ra rb rc POWER_TIME_UNKNOWNPOWER_TIME_UNLIMITEDrd rd rd re rf s rf replacesurrogateescapetotalusedfreeZpercentsinZsoutZ
read_countZ write_countZ
read_bytesZ write_bytesZ read_timeZ
write_timeZdeviceZ
mountpointZfstypeZoptsZ
bytes_sentZ
bytes_recvZ packets_sentZ packets_recvZerrinZerroutZdropinZdropoutnameZterminalhoststartedpidfdfamilytypeladdrraddrstatusaddressZnetmaskZ broadcastZptpZisupduplexZspeedZmtuZ ctx_switchesZ
interruptsZsoft_interruptsZsyscallsscpufreqcurrentminmaxshwtempZlabelhighcriticalsbatteryZsecsleftZ
power_pluggedsfanusersystem
children_userchildren_systempathidZ user_timeZ system_timerealZ effectiveZsavedZioclassvalueZ voluntaryZ involuntaryaddrZipportallZtcpZtcp4ZudpZudp4ZinetZinet4Zinet6Ztcp6Zudp6Zunixc C sr y | | d } Wn< t k
rP t | t s@ t | t rF d n d } Yn X| d k rj t | | S| Sd S)z5Calculate percentage usage of 'used' against 'total'.d g r N)ZeroDivisionError
isinstancefloatround)rn rm Zround_retrd rd re rN s
/
c sI t j f d d } f d d } i | | _ | S)a A 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()
>>>
c s^ | t t | j f } y | SWn- t k
rY | | } | <| SYn Xd S)N) frozensetsorteditemsKeyError)argskwargskeyr )cachefunrd re wrapper% s
zmemoize.<locals>.wrapperc s j d S)z Clear cache.N)clearrd )r rd re cache_clear. s z memoize.<locals>.cache_clear) functoolswrapsr )r r r rd )r r re rK s
$ c ss t j f d d f d d } f d d } i d _ | _ | _ S)a A 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()
>>> foo()
1
>>> foo()
>>> foo()
>>>
c sR j s | Sy } Wn& t k
rI | } <Yn X| Sd S)N)cache_activatedr )selfr )r r r rd re r Q s
z'memoize_when_activated.<locals>.wrapperc s
d _ d S)zActivate cache.TN)r rd )r rd re cache_activate\ s z.memoize_when_activated.<locals>.cache_activatec s d _ j d S)zDeactivate and clear cache.FN)r r rd )r r rd re cache_deactivate` s z0memoize_when_activated.<locals>.cache_deactivateF)r r r r r )r r r rd )r r r re memoize_when_activated7 s ' r c C sq y t j | } WnG t k
r\ } z' | j t j t j f k rF d SWYd d } ~ Xn Xt j | j Sd S)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)osstatOSErrorerrnoEPERMEACCESS_ISREGst_mode)r sterrrd rd re rJ l s c C sc y t j | WnG t k
rZ } z' | j t j t j f k rD d SWYd d } ~ Xn Xd Sd S)zSame as os.path.exists() but does not swallow EACCES / EPERM
exceptions, see:
http://mail.python.org/pipermail/python-dev/2012-June/120787.html
FNT)r r r r r r )r r rd rd re rM { s c C s{ t j s t d k r d SyA t j t t j } t j | | j d Wd QRXd SWn t j k
rv d SYn Xd S)z2Return True if IPv6 is supported on this platform.NF::1r T)r r )sockethas_ipv6r r
contextlibclosingbinderror)sockrd rd re rO s c C s i } d } t } x | j d | } | | k r4 P| j d | | } | | k r | | | } | | d | } | r | j } | | | <| d } q W| S)zCParse a C environ block of environment variables into a dictionary.r =r_ )r findupper)datar posZWINDOWS_Znext_posZ equal_posr r rd rd re rL s
c C sD t d k r | Sy t j | SWn t t f k
r? | SYn Xd S)zConvert a numeric socket family value to an IntEnum member.
If it's not a known member, return the numeric value itself.
N)enumr
AddressFamily
ValueErrorAttributeError)numrd rd re rP s c C sD t d k r | Sy t j | SWn t t f k
r? | SYn Xd S)zConvert a numeric socket type value to an IntEnum member.
If it's not a known member, return the numeric value itself.
N)r r Z AddressTyper r )r rd rd re rQ s c s f d d } | S)zA decorator which can be used to mark a method as deprecated
'replcement' is the method name which will be called instead.
c sS d | j f | j d k r+ | _ t j | f d d } | S)Nz8%s() is deprecated and will be removed; use %s() insteadc s/ t j d t d d t | | | S)Ncategory
stacklevelr^ )warningswarn
FutureWarninggetattr)r r r )msg replacementrd re inner s z/deprecated_method.<locals>.outer.<locals>.inner)ra __doc__r r )r r )r )r re outer s $z deprecated_method.<locals>.outerrd )r r rd )r re rI s c @ sa e Z d Z d Z d d Z d d Z d d Z d d Z d
d d Z d
d Z d
S) _WrapNumberszNWatches numbers so that they don't overflow and wrap
(reset to zero).
c C s. t j | _ i | _ i | _ i | _ d S)N) threadingLocklockr reminders
reminder_keys)r rd rd re __init__ s z_WrapNumbers.__init__c C s7 | | j | <t t | j | <t t | j | <d S)N)r r intr setr )r
input_dictrq rd rd re _add_dict s
z_WrapNumbers._add_dictc C s| | j | } t | j t | j } xF | D]> } x' | j | | D] } | j | | =qN W| j | | =q6 Wd S)zIn case the number of keys changed between calls (e.g. a
disk disappears) this removes the entry from self.reminders.
N)r r keysr r )r r rq old_dictZ gone_keysZgone_keyremkeyrd rd re _remove_dead_reminders s
"
z#_WrapNumbers._remove_dead_remindersc
C sP | | j k r# | j | | | S| j | | | j | } i } x | j D] } | | } y | | } Wn t k
r | | | <wS Yn Xg } x t t | D]{ } | | }
| | } | | f } |
| k r | j | | | 7<| j | | j | | j
|
| j | | q Wt | | | <qS W| | j | <| S)zkCache dict and sum numbers which overflow and wrap.
Return an updated copy of `input_dict`
) r r r r r rangelenr r addappendtuple)
r r rq r Znew_dictr Z input_tupleZ old_tuplebitsiZ input_valueZ old_valuer rd rd re run s2
z_WrapNumbers.runNc
C s | j t | d k r@ | j j | j j | j j n9 | j j | d | j j | d | j j | d Wd QRXd S)z>Clear the internal cache, optionally only for function 'name'.N)r r r r r pop)r rq rd rd re r % s
z_WrapNumbers.cache_clearc
C s+ | j | j | j | j f SWd QRXd S)z5Return internal cache dicts as a tuple of 3 elements.N)r r r r )r rd rd re
cache_info1 s
z_WrapNumbers.cache_info)
ra rb rc r r r r r r r rd rd rd re r s ' r c
C s% t j t j | | SWd QRXd S)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)_wnr r )r rq rd rd re rR 7 s
)r
r )rW rX rg rh )yr Z
__future__r r r r r r r sysr r collectionsr r r r r r ImportErrorr version_infor ZPY3__all__rq r r platform
startswithr r r r r r r
r ZAIXr+ r, r( r- r/ r3 r' r1 r2 r) r* r0 r. r4 r r" r! r r r# r r r r r r r$ r% r& IntEnumr` globalsupdate __members__ri rj rf getfilesystemencodingr r Zgetfilesystemencodeerrorsr rF rB r@ rA rC rG r> rD rE r? r} r r r r6 r; r< r= r8 r9 r: r7 r5 r rH rN rK r rJ rM rO rL rP rQ rI r rR r r r rd rd rd re <module> sN
5
W