Viewing File: /opt/alt/python38/lib64/python3.8/site-packages/psutil/tests/__pycache__/__init__.cpython-38.pyc
U
Œ=Ý_àà ã E @ s” d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlmZ ddlmZ ddlmZ ddl Z ddl m Z ddl m Z dd l m Z dd
l m Z dd l m!Z! dd l m"Z" dd
l m#Z# ddl$m%Z% ddl$m&Z& ddl$m'Z' ddl(m)Z) ddl(m*Z* ddl(m+Z+ ddl(m,Z, ddl(m-Z- ddl(m.Z. ddl(m/Z/ ddl(m0Z0 e+rÔddl1Z1nddl2Z1zddl1m3Z3 W n< e4k
r( e 5¡ e 6d¡ ddl3Z3W 5 Q R X Y nX ej7dkr@ddl8Z8ndZ8d d d d d d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`gEZ9daej:kZ;d e
j<kZ=dbe
j<kpúdce
j<kZ>e=pe>Z?ej@ddkZAdeZBdfZCdgZDdhZEe?rFeBdi9 ZBeEdi9 ZEeCdi9 ZCeDdi9 ZDe
jFdjkr`dke
G¡ ZHn dle
G¡ ZHe.dmƒZIe+rˆdn Jdodp¡ZKndqZKe L¡ M¡ drkZNe
jO Pe
jO Qe
jO ReS¡dsds¡¡ZTe
jO QeTdt¡ZUe
jO Pe
jO ReS¡¡ZVe!oèe" ZWeXe jYduƒZZeXe dvƒZ[eXe dwƒZ\eXe jYdxƒZ]eXe jYdyƒZ^eXe jYdzƒZ_eXe d{ƒZ`eXe jYd|ƒZaeXe jYd}ƒZbeXe jYd~ƒZceXe dƒZdzedoxeee f¡ ƒZgW n ehk
r– d€ZgY nX eXe dƒZieXe d‚ƒZjeXe jYdƒƒZke sÄe oÎe
l¡ dkZmd„d…„ Znenƒ Zoepe
jqd†ƒZre serjt¡ d‡dˆ„ eue ƒD ƒZvewed‰exƒ ƒZyezƒ Z{ezƒ Z|G dŠd‹„ d‹ej}ƒZ~dŒd„ ZedËdŽd<„ƒZ€edd>„ ƒZdd=„ Z‚ed‘d9„ ƒZƒed’d“„ ƒZ„ej…eEfd”d:„Z†dÌd•d;„Z‡d–dQ„ Zˆd—dP„ Z‰G d˜d™„ d™exƒZŠeŠe j‹deEdšd›dœdS„ ƒZŒeŠe*efdeEdšd›dÍdždT„ƒZŽeŠedeEdšd›dŸdR„ ƒZd dK„ Zd¡d¢„ Z‘ej’d£dJ„ ƒZ“dÎd¤dL„Z”dÏd¦dO„Z•G d§d¨„ d¨e1j–ƒZ–e–e1_–G d©dD„ dDe–ƒZ—e1 ˜e;dª¡G d«dC„ dCe—ƒƒZ™d¬dG„ Zšdd®„ Z›G d¯dE„ dEƒZœG d°dF„ dFƒZd±d²„ ZžeBfd³dB„ZŸdÐd´d@„Z dÑdµdA„Z¡dÒd·dV„Z¢eedfd¸dW„Z£ejfd¹dX„Z¤dÓd»dY„Z¥d¼dZ„ Z¦ej’d½d[„ ƒZ§d¾dU„ Z¨d¿dÀ„ Z©dÁd\„ ZªdÂd]„ Z«dÃd^„ Z¬dÄd`„ Ze!rZej’dÔdÅd_„ƒZ®nej’dÕdÆd_„ƒZ®ejsdÇdÈ„ ƒZ¯e!re ej…dÉdÊ„ ¡ dS )Öz
Test utilities.
é )Úprint_functionN)ÚAF_INET)ÚAF_INET6)Ú SOCK_STREAM)ÚAIX)ÚFREEBSD)ÚLINUX)ÚMACOS)ÚPOSIX)ÚSUNOS)ÚWINDOWS)Ú bytes2human)Ú print_color)Ú
supports_ipv6)ÚFileExistsError)ÚFileNotFoundError)ÚPY3)Úrange)Úsuper)Úu)Úunicode)Úwhich)ÚmockÚignore©é é ÚAPPVEYORÚDEVNULLÚGLOBAL_TIMEOUTÚTOLERANCE_SYS_MEMÚ
NO_RETRIESÚPYPYÚ
PYTHON_EXEÚROOT_DIRÚ SCRIPTS_DIRÚ
TESTFN_PREFIXÚUNICODE_SUFFIXÚINVALID_UNICODE_SUFFIXÚ
CI_TESTINGÚVALID_PROC_STATUSESÚTOLERANCE_DISK_USAGEÚIS_64BITÚHAS_CPU_AFFINITYÚ HAS_CPU_FREQÚ HAS_ENVIRONÚHAS_PROC_IO_COUNTERSÚ
HAS_IONICEÚHAS_MEMORY_MAPSÚHAS_PROC_CPU_NUMÚ
HAS_RLIMITÚHAS_SENSORS_BATTERYÚ HAS_BATTERYÚHAS_SENSORS_FANSÚHAS_SENSORS_TEMPERATURESZHAS_MEMORY_FULL_INFOÚpyrunÚ terminateÚ
reap_childrenÚspawn_testprocÚ spawn_zombieÚspawn_children_pairZThreadTaskunittestÚskip_on_access_deniedÚskip_on_not_implementedÚretry_on_failureÚTestMemoryLeakÚPsutilTestCaseÚprocess_namespaceÚsystem_namespaceÚ
print_sysinfoZ install_pipZinstall_test_depsÚchdirÚ safe_rmpathÚ
create_exeZ decode_pathZ encode_pathÚ
get_testfnÚ
get_winverÚkernel_versionÚ
call_untilÚ wait_for_pidÚ
wait_for_fileÚcheck_net_addressÚ
get_free_portÚ bind_socketÚbind_unix_socketÚtcp_socketpairÚunix_socketpairÚcreate_socketsÚ
reload_moduleÚimport_module_by_pathÚwarnÚcopyload_shared_libÚ
is_namedtupleZ__pypy__ÚGITHUB_ACTIONSZ CIBUILDWHEELl é
i P i é r Újavaz $psutil-%s-z @psutil-%s-u -Æ’Å‘Å‘s fÀ€Úutf8Úsurrogateescapeu f)Úasciizus-asciiz..ZscriptsÚ cpu_affinityÚcpu_freqÚ
getloadavgÚenvironÚioniceÚ memory_mapsÚnet_io_countersÚcpu_numÚ io_countersÚrlimitÚsensors_batteryFÚ sensors_fansÚsensors_temperaturesÚthreadsc C sÄ dd„ } t r@tr$tr tdƒS tdƒS tr6tj tj ¡S tdƒS n€t
rš| tj ƒpˆ| tj tj ¡ƒpˆ| tdtj d d… ƒƒpˆ| t
¡ ¡ ƒ}|s–tdƒ‚|S tj tj ¡}tj |¡s¼t|ƒ‚|S d S ) Nc S s< z t j| dgt jt jd W n tk
r2 Y d S X | S d S )Nz-V)ÚstdoutÚstderr)Ú
subprocessÚ
check_callÚPIPEÚ Exception)Úexe© rx úH/opt/alt/python38/lib64/python3.8/site-packages/psutil/tests/__init__.pyÚattemptÄ s ÿ
z _get_py_exe.<locals>.attemptZpypy3ÚpypyÚpythonz python%s.%sé z"can't find python exe real abspath)r\ r" r r r ÚosÚpathÚrealpathÚsysÚ
executabler Ú version_infoÚpsutilÚProcessrw Ú
ValueErrorÚexistsÚAssertionError)rz rw rx rx ry Ú _get_py_exeà s*
ÿþür‰ zr+c C s g | ]}| d ¡rtt|ƒ‘qS )ZSTATUS_©Ú
startswithÚgetattrr„ ©Ú.0Úxrx rx ry Ú
<listcomp>ç s
ÿr ÚAF_UNIXc sP e Zd ZdZ‡ fdd„Zdd„ Zdd„ Zdd „ Zd
d „ Zd d
„ Z dd„ Z
‡ Z S )Ú
ThreadTaskz6A thread task which does nothing expect staying alive.c s$ t ƒ ¡ d| _d| _t ¡ | _d S )NFçü©ñÒMbP?)r Ú__init__Ú_runningÚ _intervalÚ threadingZEventÚ_flag©Úself©Ú __class__rx ry r” ÷ s
zThreadTask.__init__c C s | j j}d|| jt| ƒf S )Nz<%s running=%s at %#x>)rœ Ú__name__r• Úid)rš Únamerx rx ry Ú__repr__ý s zThreadTask.__repr__c C s | ¡ | S ©N)Ústartr™ rx rx ry Ú __enter__ s zThreadTask.__enter__c O s | ¡ d S r¡ )Ústop)rš ÚargsÚkwargsrx rx ry Ú__exit__ s zThreadTask.__exit__c C s( | j rtdƒ‚tj | ¡ | j ¡ dS )zStart thread and keep it running until an explicit
stop() request. Polls for shutdown every 'timeout' seconds.
zalready startedN)r• r† r— ÚThreadr¢ r˜ Úwaitr™ rx rx ry r¢ s zThreadTask.startc C s( d| _ | j ¡ | j r$t | j¡ qd S )NT)r• r˜ ÚsetÚtimeÚsleepr– r™ rx rx ry Úrun s
zThreadTask.runc C s | j stdƒ‚d| _ | ¡ dS )z8Stop thread execution and and waits until it is stopped.zalready stoppedFN)r• r† Újoinr™ rx rx ry r¤ s zThreadTask.stop) r Ú
__module__Ú __qualname__Ú__doc__r” r r£ r§ r¢ r r¤ Ú
__classcell__rx rx r› ry r’ ô s r’ c s t ˆ ¡‡ fdd„ƒ}|S )Nc s. z ˆ | |ŽW S t k
r( tƒ ‚ Y nX d S r¡ )rv r; ©r¥ r¦ ©Úfunrx ry Úwrapper% s
z&_reap_children_on_err.<locals>.wrapper©Ú functoolsÚwraps©rµ r¶ rx r´ ry Ú_reap_children_on_err$ s r» c K sÐ | dt¡ | dt¡ | dt ¡ ¡ | dtj¡ trJd}| d|¡ | dkrªtƒ }zDt|ƒ d| }td |g} t j
| f|Ž}t |¡ t
|d
d
d W 5 t|ƒ X n"t j
| f|Ž}t |¡ t|jƒ |S ) a} Creates a python subprocess which does nothing for 60 secs and
return it as a subprocess.Popen instance.
If "cmd" is specified that is used instead of python.
By default stdin and stdout are redirected to /dev/null.
It also attemps to make sure the process is in a reasonably
initialized state.
The process is registered for cleanup on reap_children().
Ústdinrq ÚcwdÚenvé Ú
creationflagsNz:from time import sleep;open(r'%s', 'w').close();sleep(60);z-cT©ÚdeleteÚempty)Ú
setdefaultr r~ Úgetcwdrf r rJ rH r# rs ÚPopenÚ_subprocesses_startedÚaddrO rN Úpid)ÚcmdÚkwdsZCREATE_NO_WINDOWÚtestfnZpylineÚsprocrx rx ry r< / s.
þ
c C s¬ d} t t ¡ d}zzt dtj |¡tf ¡}t rDt
|dd\}} n t
|ƒ\}} t |j
¡}tt|dddƒ}t |¡ t |¡}||fW ¢S t|ƒ | dk r¦t| ƒ X dS ) a Create a subprocess which creates another one as in:
A (us) -> B (child) -> C (grandchild).
Return a (child, grandchild) tuple.
The 2 processes are fully initialized and will live for 60 secs
and are registered for cleanup on reap_children().
N©Údira; import subprocess, os, sys, time
s = "import os, time;"
s += "f = open('%s', 'w');"
s += "f.write(str(os.getpid()));"
s += "f.close();"
s += "time.sleep(60);"
p = subprocess.Popen([r'%s', '-c', s])
p.wait()
r )rÀ TFrÁ )rJ r~ rÅ rH ÚtextwrapÚdedentr Úbasenamer# r r9 r„ r… rÉ ÚintrO Ú
_pids_startedrÈ )ÚtfilerÌ ÚsÚsubpZchildZgrandchild_pidZ
grandchildrx rx ry r> W s" ÷
c sÞ t js
t‚tƒ } t d| ¡}d}t| ƒ}zŒ| t
¡ t |ƒ\}}| ¡ \}}zZt
| ¡ gg g t
¡ t| d¡ƒ}t |¡ t |¡‰ t‡ fdd„dƒ |ˆ fW ¢W ¢S | ¡ X W 5 | ¡ t| ƒ |dk rØt|ƒ X dS )z±Create a zombie process and return a (parent, zombie) process tuple.
In order to kill the zombie parent must be terminate()d first, then
zombie must be wait()ed on.
a import os, sys, time, socket, contextlib
child_pid = os.fork()
if child_pid > 0:
time.sleep(3000)
else:
# this is the zombie process
s = socket.socket(socket.AF_UNIX)
with contextlib.closing(s):
s.connect('%s')
if sys.version_info < (3, ):
pid = str(os.getpid())
else:
pid = bytes(str(os.getpid()), 'ascii')
s.sendall(pid)
Né c s ˆ ¡ S r¡ )Ústatusrx ©Úzombierx ry Ú<lambda> ó z spawn_zombie.<locals>.<lambda>zret == psutil.STATUS_ZOMBIE)r„ r
rˆ rJ rÐ rÑ rS ÚcloserH Z
settimeoutr r9 ÚacceptÚselectÚfilenorÓ ZrecvrÔ rÈ r… rM )Z unix_fileÚsrcrÕ ÚsockÚparentÚconnÚ_Zzpidrx rÚ ry r= ~ s.
ñ
c K sˆ | dd¡ | dd¡ tƒ }zFt|dƒ}| | ¡ W 5 Q R X tt|jgf|Ž}t|jƒ ||fW S t k
r‚ t
|ƒ ‚ Y nX dS )zRun python 'src' code string in a separate interpreter.
Returns a subprocess.Popen instance and the test file where the source
code was written.
rq Nrr Úwt) rÄ rJ ÚopenÚwriter< r# rŸ rN rÉ rv rH )râ rË ÚsrcfileÚfr× rx rx ry r9 « s
c K sØ t | ttfƒrdnd}tr"|r"dnd}| d|¡ | dtj¡ | dtj¡ | dd¡ | d |¡ tj| f|Ž}t |¡ t
r”|j t d
\}}n | ¡ \}}|j
dkr²t|ƒ‚|r¾t|ƒ | d ¡rÔ|d d
… }|S )zUrun cmd in a subprocess and return its output.
raises RuntimeError on error.
TFr¿ r Úshellrq rr Zuniversal_newlinesrÀ ©ÚtimeoutÚ
Néÿÿÿÿ)Ú
isinstanceÚstrr r rÄ rs ru rÆ rÇ rÈ r Z communicater Ú
returncodeÚ RuntimeErrorrY Úendswith)rÊ rË rì ÚflagsÚprq rr rx rx ry Úsh¿ s&
rø c
s t rddlm‰ dd„ ‰dd„ ‰ ‡ ‡‡fdd„}‡ ‡‡fd d
„‰‡‡fd d „}d
d„ }| }zbt|tƒrt|||ƒW ¢LS t|tj tjfƒr”ˆ||ƒW ¢,S t|tjƒr®|||ƒW ¢S t d| ƒ‚W 5 t|tjtjfƒrØ||ƒ t|tƒræ|n|j}t |¡r t
|ƒ‚X dS )a˜ Terminate a process and wait() for it.
Process can be a PID or an instance of psutil.Process(),
subprocess.Popen() or psutil.Popen().
If it's a subprocess.Popen() or psutil.Popen() instance also closes
its stdin / stdout / stderr fds.
PID is wait()ed even if the process is already gone (kills zombies).
Does nothing if the process does not exist.
Return process exit status.
r )Úwait_pidc S sd t | tjƒrts| ¡ n
| |¡ tr`t | tjƒr`zt | j¡ |¡W S tj k
r^ Y nX d S r¡ )
rñ rs rÆ r r© r r„ r… rÉ Ú
NoSuchProcess©Úprocrî rx rx ry r© è s
zterminate.<locals>.waitc S s6 t rtrtj}tr(|tjkr(| tj¡ | |¡ d S r¡ )r r\ ÚsignalÚSIGKILLr
Ú send_signalÚSIGCONT)rü Úsigrx rx ry Úsendsigô s
zterminate.<locals>.sendsigc
sZ zˆ | ˆƒ W n@ t k
rN } z"tr0|jdkr0n|jtjkr>‚ W 5 d }~X Y nX ˆ| |ƒS )Né )ÚOSErrorr ZwinerrorÚerrnoZESRCH)rü rî Úerr©r r r© rx ry Ú term_subprocþ s z terminate.<locals>.term_subprocc s0 zˆ | ˆƒ W n t jk
r$ Y nX ˆ| |ƒS r¡ )r„ rú rû r rx ry Ú term_psproc s
z terminate.<locals>.term_psprocc sF zt | ¡}W n( t jk
r6 tr2ˆ| |ƒ Y S Y n X ˆ ||ƒS d S r¡ )r„ r… rú r
)rÉ rî rü )r rù rx ry Úterm_pid s zterminate.<locals>.term_pidc S s4 | j r| j ¡ | jr | j ¡ | jr0| j ¡ d S r¡ )rq rÞ rr r¼ )rü rx rx ry Ú flush_popen s
z terminate.<locals>.flush_popenz
wrong type %rN)
r
Zpsutil._psposixrù rñ rs rÆ r„ rÓ rÉ Ú
pid_existsrˆ r… Ú TypeError)Z proc_or_pidr Ú wait_timeoutr r
r r÷ rÉ rx )r r r r© rù ry r: Û s*
c C s t ¡ j| d}tr&t ¡ }t|ƒ qtr<t ¡ }t|ƒ q&|rŒ|D ]}t|dd qDt j|td\}}|D ] }t d| ƒ t|t
j d qldS )a Terminate and wait() any subprocess started by this test suite
and any children currently running, ensuring that no processes stick
around to hog resources.
If resursive is True it also tries to terminate and wait()
all grandchildren started by this process.
©Ú recursiveN)r rí z0couldn't terminate process %r; attempting kill())r ) r„ r… ÚchildrenrÇ Úpopr: rÔ Ú
wait_procsr rY rý rþ )r r r× rÉ r÷ ZgoneZaliverx rx ry r; 3 s
c C s¬ t s tdƒ‚d} t ¡ d }|D ]"}| ¡ s4|dkr>| |7 } q qDq | sTtd| ƒ‚d}d}| d¡}t|d ƒ}t|ƒdkrŠt|d ƒ}t|ƒdkr¢t|d ƒ}|||fS ) z"Return a tuple such as (2, 6, 36).z not POSIXÚ r} Ú.zcan't parse %rr é r ) r
ÚNotImplementedErrorr~ ÚunameÚisdigitr† ÚsplitrÓ Úlen)rÖ r ÚcÚminorÚmicroZnumsÚmajorrx rx ry rL X s&
c C sd t s tdƒ‚t ¡ } t| dƒr*| jp&d}n(t d| d ¡}|rNt| d¡ƒ}nd}| d | d |fS )Nz not WINDOWSÚservice_pack_majorr z\s\d$r r )
r r r ZgetwindowsversionÚhasattrr ÚreÚsearchrÓ Úgroup)ZwvZspÚrrx rx ry rK p s
c @ s< e Zd ZdZeddddfdd„Zdd„ Zdd „ Zd
d „ ZdS ) ÚretryzA retry decorator.Nr“ c C s2 |r|rt dƒ‚|| _|| _|| _|| _|| _d S )Nz/timeout and retries args are mutually exclusive)r† Ú exceptionrî ÚretriesÚintervalÚlogfun)rš r' rî r( r) r* rx rx ry r” ‡ s zretry.__init__c c sT | j r*t ¡ | j }t ¡ |k rPd V qn&| jrHt| jƒD ]
}d V q:nd V qHd S r¡ )rî r« r( r )rš Ústop_atræ rx rx ry Ú__iter__– s
zretry.__iter__c C s | j d k rt | j ¡ d S r¡ )r) r« r¬ r™ rx rx ry r¬ ¢ s
z retry.sleepc s" t ˆ ¡‡ ‡fdd„ƒ}ˆ|_|S )Nc s| d }ˆD ]b}zˆ | |ŽW S ˆj k
rh } z,|}ˆjd k rHˆ |¡ ˆ ¡ W Y ¢qW 5 d }~X Y qX qtrv|‚n‚ d S r¡ )r' r* r¬ r )r¥ r¦ Úexcræ ©rµ rš rx ry r¶ § s
z retry.__call__.<locals>.wrapper)r¸ r¹ Ú decorator)rš rµ r¶ rx r. ry Ú__call__¦ s zretry.__call__) r r¯ r° r± rv r” r, r¬ r0 rx rx rx ry r& „ s û
r& r“ )r' r* rî r) c C s t | ¡ trt d¡ dS )z„Wait for pid to show up in the process list then return.
Used in the test suite to give time the sub process to initialize.
ç{®Gáz„?N)r„ r… r r« r¬ )rÉ rx rx ry rN ¾ s
Tc C s: t | dƒ}| ¡ }W 5 Q R X |s*|s*t‚|r6t| ƒ |S )z8Wait for a file to be written on disk with some content.Úrb)rè Úreadrˆ rH )Úfnamer rà rë Údatarx rx ry rO Ê s c C s | ƒ }t |ƒst‚|S )zVKeep calling function for timeout secs and exit if eval()
expression is True.
)Úevalrˆ )rµ ÚexprÚretrx rx ry rM × s c C sn dd„ }zLt | ¡}t |j¡r0t tj| ¡}nt t j| ¡}t rJ|ƒ n||ƒ W n t
k
rh Y nX dS )z>Convenience function for removing temporary test files or dirsc
S s~ t ¡ t }t ¡ |k rvz| ƒ W S tk
r4 Y n6 tk
rh } z|}tdt|ƒ ƒ W 5 d }~X Y nX t d¡ q |‚d S )Nz ignoring %sr1 )r« r r Z WindowsErrorrY rò r¬ )rµ r+ ræ r rx rx ry Ú retry_funé s " z safe_rmpath.<locals>.retry_funN) r~ ÚstatÚS_ISDIRÚst_moder¸ ÚpartialÚshutilZrmtreeÚremover
r )r r9 Ústrµ rx rx ry rH ç s
c C s( zt | ¡ W n tk
r" Y nX dS )z-Convenience function for creating a directoryN)r~ Úmkdirr rÎ rx rx ry Ú
safe_mkdir s rB c c s. t ¡ }zt | ¡ dV W 5 t |¡ X dS )z@Context manager which temporarily changes the current directory.N)r~ rÅ rG )ÚdirnameÚcurdirrx rx ry rG s
c C sÎ t j | ¡rt| ƒ‚|rœtdƒs(tdƒ‚t|tƒr<t d¡}t|t
ƒsNt|ƒ‚t t dddƒ}|
|¡ W 5 Q R X zt d|jd| g¡ W 5 t|jƒ X n.t t| ¡ trÊt | ¡}t | |jtjB ¡ dS ) z1Creates an executable file in the given location.Úgcczgcc is not installedzŸ
#include <unistd.h>
int main() {
pause();
return 1;
}
z.c©Úsuffixrç z-oN)r~ r r‡ rˆ r r† rñ ÚboolrÐ rÑ rò rè rJ ré rH rŸ rs rt r> Úcopyfiler# r
r: Úchmodr< ÚS_IEXEC)ZoutpathZc_coderë r@ rx rx ry rI s$
ÿ
r c C s. t jt| |d}tj |¡s tj |¡S q dS )zîReturn an absolute pathname of a file or dir that did not
exist at the time this call is made. Also schedule it for safe
deletion at interpreter exit. It's technically racy but probably
not really due to the time variant.
)ÚprefixrG rÏ N)ÚtempfileZmktempr& r~ r r‡ r€ )rG rÏ rŸ rx rx ry rJ 9 s c @ s4 e Zd Zdd„ Zeejdƒs$ejjZe s0dd„ Z
dS )ÚTestCasec C s. | j j}| d¡sd| }d|| j j| jf S )Nzpsutil.z
psutil.tests.z%s.%s.%s)rœ r¯ r‹ r Z_testMethodName)rš Zfqmodrx rx ry Ú__str__N s
ÿzTestCase.__str__ÚassertRaisesRegexc C s d S r¡ rx r™ rx rx ry ÚrunTest\ s zTestCase.runTestN) r r¯ r° rO r! ÚunittestrN ZassertRaisesRegexprP r rQ rx rx rx ry rN J s
rN c @ sB e Zd ZdZddd„Zdd„ Zdd „ Zd
d „ Zd d
„ Zdd„ Z dS )rC zUTest class providing auto-cleanup wrappers on top of process
test utilities.
r Nc C s t ||d}| t|¡ |S )N)rG rÏ )rJ Ú
addCleanuprH )rš rG rÏ r4 rx rx ry rJ i s zPsutilTestCase.get_testfnc O s t ||Ž}| t|¡ |S r¡ )r< rS r: )rš r¥ rË rÍ rx rx ry r< n s
z PsutilTestCase.spawn_testprocc C s* t ƒ \}}| t|¡ | t|¡ ||fS r¡ )r> rS r: )rš Zchild1Zchild2rx rx ry r> s s
z"PsutilTestCase.spawn_children_pairc C s* t ƒ \}}| t|¡ | t|¡ ||fS r¡ )r= rS r: )rš rä rÛ rx rx ry r= y s
zPsutilTestCase.spawn_zombiec O s* t ||Ž\}}| t|¡ | t|¡ |S r¡ )r9 rS rH r: )rš r¥ rË rÍ rê rx rx ry r9 s zPsutilTestCase.pyrunc C sš | tjtj|j¡ t|tjtjfƒrn| ¡ r2t‚z | ¡ }W n tjk
rT Y nX td| ƒ‚|j
dd t |j¡r„t|jƒ‚| |jt
¡ ¡ d S )Nz3Process.status() didn't raise exception (status=%s)r rí )Ú assertRaisesr„ rú r… rÉ rñ rÆ Ú
is_runningrˆ rÙ r© r Z assertNotInÚpids)rš rü rÙ rx rx ry ÚassertProcessGone… s ÿ z PsutilTestCase.assertProcessGone)r N)
r r¯ r° r± rJ r< r> r= r9 rW rx rx rx ry rC d s
zunreliable on PYPYc @ s~ e Zd ZdZdZdZdZer dndZdZ e
¡ Z dd„ Z
d d
„ Zd d „ Zd
d„ Zdd„ Zdd„ Zdd„ Zddd„Zdd„ ZdS )rB aç Test framework class for detecting function memory leaks,
typically functions implemented in C which forgot to free() memory
from the heap. It does so by checking whether the process memory
usage increased before and after calling the function many times.
Note that this is hard (probably impossible) to do reliably, due
to how the OS handles memory, the GC and so on (memory can even
decrease!). In order to avoid false positives, in case of failure
(mem > 0) we retry the test for up to 5 times, increasing call
repetitions each time. If the memory keeps increasing then it's a
failure.
If available (Linux, OSX, Windows), USS memory is used for comparison,
since it's supposed to be more precise, see:
https://gmpy.dev/blog/2016/real-process-memory-and-environ-in-python
If not, RSS memory is used. mallinfo() on Linux and _heapwalk() on
Windows may give even more precision, but at the moment are not
implemented.
PyPy appears to be completely unstable for this framework, probably
because of its JIT, so tests on PYPY are skipped.
Usage:
class TestLeaks(psutil.tests.TestMemoryLeak):
def test_fun(self):
self.execute(some_function)
éÈ r] r r^ Tc C s | j ¡ }t|d|jƒS )NZuss)Ú _thisprocÚmemory_full_inforŒ Zrss)rš Úmemrx rx ry Ú_get_mem¼ s
zTestMemoryLeak._get_memc C s t r| j ¡ S | j ¡ S d S r¡ )r
rY Únum_fdsÚ num_handlesr™ rx rx ry Ú _get_num_fds s
zTestMemoryLeak._get_num_fdsc C s | j rt|dtjd d S )NZyellow)ZcolorÚfile)Úverboser r rr )rš Úmsgrx rx ry Ú_logÈ s zTestMemoryLeak._logc C sx | ¡ }| |¡ | ¡ }|| }|dk r8| d| ¡‚|dkrttrHdnd}|dkr\|d7 }d|||f }| |¡‚dS ) z»Makes sure num_fds() (POSIX) or num_handles() (Windows) does
not increase after calling a function. Used to discover forgotten
close(2) and CloseHandle syscalls.
r zHnegative diff %r (gc probably collected a resource from a previous test)ÚfdZhandler rÖ z %s unclosed %s after calling %rN)r_ ÚcallÚfailr
)rš rµ ZbeforeZafterÚdiffZtype_rb rx rx ry Ú
_check_fdsÌ s
ÿ zTestMemoryLeak._check_fdsc C s^ t jdd | ¡ }t|ƒD ]}| |¡}~~q t jdd | ¡ }| t jg ¡ || }|S )z€Get 2 distinct memory samples, before and after having
called fun repeadetly, and return the memory difference.
r )Z
generation)ÚgcZcollectr\ r re Z assertEqualZgarbage)rš rµ ÚtimesZmem1r r8 Zmem2rg rx rx ry Ú _call_ntimesß s
zTestMemoryLeak._call_ntimesc
C s¶ g }d}|}t d|d ƒD ]†} | ||¡}
d| t|
ƒt|
| ƒ|f } | | ¡ |
|kp^|
|k} | r|| dkrv| | ¡ d S | dkrŠtƒ | | ¡ ||7 }|
}q| d |¡¡‚d S )Nr r z,Run #%s: extra-mem=%s, per-call=%s, calls=%sz. )r rk r
Úappendrc Úprintrf r® )
rš rµ rj Ú warmup_timesr( Ú toleranceZmessagesZprev_memZincreaseÚidxr[ rb Úsuccessrx rx ry Ú
_check_memî s.
ÿ
zTestMemoryLeak._check_memc C s |ƒ S r¡ rx )rš rµ rx rx ry re s zTestMemoryLeak.callNc
C sê |dk r |n| j }|dk r |n| j}|dk r0|n| j}|dk rB|n| j}zD|dksZtdƒ‚|dksjtdƒ‚|dksztdƒ‚|dksŠtdƒ‚W n. tk
rº } ztt|ƒƒ‚W 5 d}~X Y nX | ||¡ | |¡ | j |||||d dS ) zTest a callable.Nr ztimes must be >= 1r zwarmup_times must be >= 0zretries must be >= 0ztolerance must be >= 0)rj rn r( ro )
rj rn r( ro rˆ r† rò rk rh rr )rš rµ rj rn r( ro r rx rx ry Úexecute s& ÿ
ÿzTestMemoryLeak.executec s" ‡ ‡‡fdd„}ˆj |f|Ž dS )znConvenience method to test a callable while making sure it
raises an exception on every call.
c s ˆ ˆ ˆ¡ d S r¡ )rT rx ©r- rµ rš rx ry re " s z*TestMemoryLeak.execute_w_exc.<locals>.callN)rs )rš r- rµ r¦ re rx rt ry Ú
execute_w_exc s z TestMemoryLeak.execute_w_exc)NNNN)r r¯ r° r± rj rn ro r) r( ra r„ r… rY r\ r_ rc rh rk rr re rs ru rx rx rx ry rB • s$ ÿ
c C s° dd l } dd l}dd l}dd l}dd l}dd l}z dd l}W n tk
rT d }Y nX z dd l}W n tk
rz d }Y nX | ¡ }t
j r t dƒr t
dƒ|d< n~t
jr¼d| ¡ d |d< nbt
jrdd tt| ¡ ƒ¡ |d< t|dƒr |d d | ¡ 7 < nd
| ¡ | ¡ f |d< d t| ¡ ƒ| ¡ g ¡|d < t
j rV| ¡ d |d
< d | ¡ | ¡ | ¡ g¡|d< t!|ddƒ|d< |d k r¦|d d|j" 7 < t
j rþt dƒrÜt
ddgƒ} t| ƒ #d¡d |d< nd|d< | $¡ d }
|
rþ|
|d< t% &¡ |d< | '¡ } d| d | d f |d< |j (t
)¡ ¡ *d¡|d < |j +¡ *d¡|d < | ,¡ |d < t-j. /d ¡|d < t- 0¡ |d!< t1|d"< | 2¡ |d#< t- 3¡ |d$< t
4¡ |d%< d&t5d'd(„ t
6¡ D ƒƒ |d)< t
7¡ } d*t8| j9ƒt:| j;ƒt:| j<ƒf |d+< t
=¡ }
d*t8|
j9ƒt:|
j;ƒt:|
j<ƒf |d,< t>t
?¡ ƒ|d-< t
@¡ A¡ }| Bd.d ¡ | C|¡|d/< tDd0t%jEd1 | F¡ D ]$\}}tDd2|d3 |f t%jEd1 qntDd0t%jEd1 t%jG H¡ d S )4Nr Z lsb_releasezlsb_release -d -sZOSz Darwin %szWindows ú Ú
win32_editionz, z%s %sZarchr} Zkernelr| Ú __version__z
not installedÚpipz (wheel=%s)rE z --versionrï r Zglibcz fs-encodingz%s, %sÚlangz%Y-%m-%d %H:%M:%Sz boot-timer« Úuserú~Úhomer½ ZpyexeZhostnameZPIDZcpusz%.1f%%, %.1f%%, %.1f%%c S s g | ]}|t ¡ d ‘qS )éd )r„ Ú cpu_countr rx rx ry r p s z!print_sysinfo.<locals>.<listcomp>Zloadavgz%s%%, used=%s, total=%sZmemoryÚswaprV rh rü zF======================================================================©r` z%-17s %sú:)IÚ collectionsÚdatetimeÚgetpassÚlocaleÚplatformÚpprintry Ú ImportErrorÚwheelÚ OrderedDictr„ r r rø ZOSXZmac_verr r® Úmaprò Z win32_verr! rw ÚsystemÚversionÚlistZ architectureÚmachiner
r Zpython_implementationZpython_versionZpython_compilerrŒ rx r Zlibc_verr ÚgetfilesystemencodingZ getlocaleZ
fromtimestampÚ boot_timeÚstrftimeZnowZgetuserr~ r Ú
expanduserrÅ r# ZnodeÚgetpidr Útuplere Úvirtual_memoryrÓ Zpercentr
ZusedZtotalÚ swap_memoryr rV r… Úas_dictr Zpformatrm rr Úitemsrq Úflush)rƒ r„ r… r† r‡ rˆ ry rŠ ÚinfoÚoutrÖ rz r[ r€ ZpinfoÚkÚvrx rx ry rF ( s®
ÿ
ÿý
ÿÿ ÿ ÿ
ÿ
c C s6 t ¡ } t| dƒr| ¡ S t| dƒr2t | ¡ ¡S dS )Nrj rc r )r„ r… r! rj ÚrandomÚchoicerc )r÷ rx rx ry Ú_get_eligible_cpuƒ s
r¢ c @ sB e Zd ZdZddi fddi fgZddi fddddifd di fd
di fd di fd di fd
di fddi fddi fg Zddi fddddifddi fddi fddi fddi fddi fddi fddi fd di fd di fd di fd di fd di fd!di fd"di fd#di fgZerFed$di fg7 Zed%di fg7 Zed&di fg7 Zed'di fg7 Zer\ed(di fg7 Ze rred)di fg7 Ze
rŒed*e j fi fg7 Ze
r¢ed+di fg7 Zer¸ed,di fg7 ZerÎed-di fg7 Zeräed.di fg7 Zerþed/dd0d1ifg7 Zg Zered di fg7 Zned e jfi fg7 Ze
rJed*e j d2fi fg7 Ze r‚erned)e jd3fi fg7 Zned)e jfi fg7 Ze
ržed+eƒ gfi fg7 Zd4ejfi fd5di fd6di fd7di fd8di fgZerüed4ejfi fg7 Zed4ej fi fg7 Zee e e Z d9d:„ Z dDd;d<„Z d=d>„ Z e!d?d@„ ƒZ"e!dAdB„ ƒZ#dCS )ErD a A container that lists all Process class method names + some
reasonable parameters to be called with. Utility methods (parent(),
children(), ...) are excluded.
>>> ns = process_namespace(psutil.Process())
>>> for fun, name in ns.iter(ns.getters):
... fun()
Ú cpu_percentrx Zmemory_percentr™ r r TrU Zmemory_info_exZoneshoträ ÚparentsrÉ r© ©r ZcmdlineZ connectionsÚkindÚallÚ cpu_timesZ create_timer½ rw rZ Z memory_inforŸ ÚniceZnum_ctx_switchesZ num_threadsZ
open_filesZppidrÙ rp ZusernameZuidsZgidsZterminalr] rk rg rl rc rj rf r^ rh ZgroupedF)rØ i r rÿ ZsuspendZresumer: Úkillc C s
|| _ d S r¡ )Ú_proc)rš rü rx rx ry r” ë s zprocess_namespace.__init__c c sZ t |ƒ}t |¡ |D ]>\}}}|r,| ¡ t| j|ƒ}tj|f|ž|Ž}||fV qdS ©z_Given a list of tuples yields a set of (fun, fun_name) tuples
in random order.
N)r r ÚshuffleÚ clear_cacherŒ r« r¸ r= )rš Úlsr® Úfun_namer¥ rË rµ rx rx ry Úiterî s
zprocess_namespace.iterc C s | j j| j jdd dS )z&Clear the cache of a Process instance.T)Z _ignore_nspN)r« Z_initrÉ r™ rx rx ry r® û s z process_namespace.clear_cachec C s> |D ]4\}}}d| }t ||ƒsd|jj|f }t|ƒ‚qdS )z}Given a TestCase instance and a list of tuples checks that
the class defines the required test method names.
Ztest_z$%r class should define a '%s' methodN)r! rœ r ÚAttributeError)ÚclsZ
test_classr¯ r° ræ Z meth_namerb rx rx ry Útest_class_coverageÿ s
ÿz%process_namespace.test_class_coveragec C s` t dd„ | jD ƒƒ}t dd„ | jD ƒƒ}t dd„ ttjƒD ƒƒ}||B |A }|r\td| ƒ‚d S )Nc S s g | ] }|d ‘qS r¥ rx r rx rx ry r
s z*process_namespace.test.<locals>.<listcomp>c S s g | ] }|d ‘qS r¥ rx r rx rx ry r s c S s g | ]}|d dkr|‘qS )r ræ rx r rx rx ry r s z!uncovered Process class names: %r)rª r§ ÚignoredrÏ r„ r… r† )r³ Úthisrµ ÚklassZleftoutrx rx ry Útest s zprocess_namespace.testN)T)$r r¯ r° r± Zutilsrµ Úgettersr
r0 r1 r4 r„ Z
RLIMIT_NOFILEr- r3 r/ r r2 ZsettersZNORMAL_PRIORITY_CLASSr ZIOPRIO_CLASS_NONEZ
IOPRIO_NORMALr¢ rý ÚSIGTERMZkillersZ CTRL_C_EVENTZCTRL_BREAK_EVENTr§ r” r± r® Ú classmethodr´ r¸ rx rx rx ry rD Œ s¤ þ ÷
ï û
c @ s¦ e Zd ZdZddi fddddifddddifddi fd dd
difd dd
difd dd difd
dddifde ¡ fi fddddifddi fddi fddddifde ¡ fi fddi fddi fddi fddi fgZeräeddd
difg7 Ze røed di fg7 Ze
red di fg7 Ze r$ed di fg7 Ze r:ed di fg7 Ze
r`ed di fg7 Zed!d"i fg7 Zd#di fd$e ¡ gfi fd%di fd&di fgZeZed'd(„ ƒZejZd)S )*rE zÝA container that lists all the module-level, system-related APIs.
Utilities such as cpu_percent() are excluded. Usage:
>>> ns = system_namespace
>>> for fun, name in ns.iter(ns.getters):
... fun()
r’ rx r ZlogicalFTZ cpu_statsr¨ ZpercpuZdisk_io_countersZperdiskZdisk_partitionsr§ Z
disk_usageZnet_connectionsr¦ Z net_if_addrsZ net_if_statsri Zpernicr rV r˜ Zusersr— rd re ro rn rm Zwin_service_iterZwin_service_get)ZalgZ process_iterr r£ Zcpu_times_percentc c sL t | ƒ} t | ¡ | D ]0\}}}tt|ƒ}tj|f|ž|Ž}||fV qdS r¬ )r r r rŒ r„ r¸ r= )r¯ r° r¥ rË rµ rx rx ry r± H s
zsystem_namespace.iterN)r r¯ r° r± r~ rÅ r• r¹ r. ÚHAS_GETLOADAVGr8 r7 r5 r r„ r… rµ r§ Ú staticmethodr± rD r´ rx rx rx ry rE sT îü
c C s t | ¡st| ƒ‚d| _| S )zA decorator to mark a TestCase class. When running parallel tests,
class' unit tests will be run serially (1 process).
T)ÚinspectZisclassrˆ Z
_serialrun)r· rx rx ry Ú serialrunW s r¿ c C s dd„ }t td| |dS )zZDecorator which runs a test function and retries N times before
actually failing.
c S s t d| tjd d S )Nz %r, retryingr )rm r rr )r- rx rx ry r* e s z retry_on_failure.<locals>.logfunN)r' rî r( r* )r& rˆ )r( r* rx rx ry rA a s ÿc s ‡ fdd„}|S )z,Decorator to Ignore AccessDenied exceptions.c s t ˆ ¡‡ ‡fdd„ƒ}|S )Nc s@ z ˆ | |ŽW S t jk
r: ˆd k r,ˆs,‚ t d¡‚Y nX d S )Nzraises AccessDenied)r„ Z AccessDeniedrR ÚSkipTestr³ ©rµ Úonly_ifrx ry r¶ o s z9skip_on_access_denied.<locals>.decorator.<locals>.wrapperr· rº ©r r´ ry r/ n s z(skip_on_access_denied.<locals>.decoratorrx ©r r/ rx rà ry r? l s c s ‡ fdd„}|S )z3Decorator to Ignore NotImplementedError exceptions.c s t ˆ ¡‡ ‡fdd„ƒ}|S )Nc sH z ˆ | |ŽW S t k
rB ˆd k r*ˆs*‚ dˆ j }t |¡‚Y nX d S )Nz4%r was skipped because it raised NotImplementedError)r r rR rÀ )r¥ r¦ rb rÁ rx ry r¶ s ÿz;skip_on_not_implemented.<locals>.decorator.<locals>.wrapperr· rº rà r´ ry r/ ~ s
z*skip_on_not_implemented.<locals>.decoratorrx rÄ rx rà ry r@ | s
ú 127.0.0.1c
C s@ t t ¡ ¡(}| | df¡ | ¡ d W 5 Q R £ S Q R X dS )z6Return an unused TCP port. Subject to race conditions.r r N)Ú
contextlibÚclosingÚsocketÚbindÚ getsockname)Zhostrã rx rx ry rQ ” s c C sˆ |dkr| t tfkrd}t | |¡}z@tjdkrB| tjtjd¡ | |¡ |tj kr`|
d¡ |W S t k
r‚ | ¡ ‚ Y nX dS )zBinds a generic socket.N©r r )ÚntÚcygwinr r^ )
r r rÈ r~ rŸ Z
setsockoptZ
SOL_SOCKETZ SO_REUSEADDRrÉ r Úlistenrv rÞ )ÚfamilyÚtypeÚaddrrã rx rx ry rR › s
c C sr t js
t‚tj | ¡r t| ƒ‚t tj|¡}z"| | ¡ |tj krL|
d¡ W n t k
rl | ¡ ‚ Y nX |S )zBind a UNIX socket.r^ )
r„ r
rˆ r~ r r‡ rÈ r‘ rÉ r rÎ rv rÞ )rŸ rÐ rã rx rx ry rS ¬ s
rË c
C s´ t t | t¡¡˜}| |¡ | d¡ | ¡ }t | t¡}zJ| |¡ | ¡ }| ¡ \}}||krz||fW W 5 Q R £ S | ¡ qPW n t
k
r¤ | ¡ ‚ Y nX W 5 Q R X dS )z^Build a pair of TCP sockets connected to each other.
Return a (server, client) tuple.
r^ N) rÆ rÇ rÈ r rÉ rÎ rÊ Úconnectrß rÞ r )rÏ rÑ Zllr ZcaddrÚarx rx ry rT » s
c C s’ t js
t‚d }}z@t| tjd}| d¡ t tjtj¡}| d¡ | | ¡ W n6 t k
rˆ |dk rr|
¡ |dk r‚|
¡ ‚ Y nX ||fS )zƒBuild a pair of UNIX sockets connected to each other through
the same UNIX file name.
Return a (server, client) tuple.
N©rÐ r ) r„ r
rˆ rS rÈ r Z setblockingr‘ rÒ rv rÞ )rŸ ZserverZclientrx rx ry rU Ò s
c c sì g } d }}z¨| ttjtjƒ¡ | ttjtjƒ¡ tƒ rd| ttj tjƒ¡ | ttj tjƒ¡ t
r¬t r¬t ƒ }t ƒ }t
|ƒ\}}t|tjd}|||fD ]}| |¡ qœ| V W 5 | D ] }| ¡ qº||fD ]}|dk rÐt|ƒ qÐX dS )z1Open as many socket families / types as possible.NrÔ )rÞ rH rl rR rÈ r r Ú
SOCK_DGRAMr r r
ÚHAS_CONNECTIONS_UNIXrJ rU rS )ZsocksZfname1Zfname2rÖ r4 Ús1Ús2Zs3rx rx ry rV é s*
c C s ddl }tr(tr(ts(t|tjƒs(t|ƒ‚|tjkršdd„ | d¡D ƒ}t
|ƒdksZt| ƒ‚|D ]"}d| krvdks^n t| ƒ‚q^tsŽt | ƒ} | | ¡ nb|tj
krÎt| tƒs¶t| ƒ‚tsÂt | ƒ} | | ¡ n.|tjkròt d| ¡dk süt| ƒ‚n
td |ƒ‚dS )
z[Check a net address validity. Supported families are IPv4,
IPv6 and MAC addresses.
r Nc S s g | ] }t |ƒ‘qS rx )rÓ r rx rx ry r s z%check_net_address.<locals>.<listcomp>r r éÿ z([a-fA-F0-9]{2}[:|\-]?){6}zunknown family %r)Ú ipaddressÚenumr r" rñ ÚIntEnumrˆ rÈ r r r r Z IPv4Addressr rò Z IPv6Addressr„ ZAF_LINKr" Úmatchr† )rÑ rÏ rÚ ZoctsZnumrx rx ry rP s&
c C sT dd„ }dd„ }dd„ }dd„ }d d
„ }|| ƒ || ƒ || ƒ || ƒ || ƒ d S ) z*Check validity of a connection namedtuple.c S sÔ t | ƒdk}t | ƒdks$tt | ƒƒ‚| d | jks<t| jƒ‚| d | jksTt| jƒ‚| d | jkslt| jƒ‚| d | jks„t| jƒ‚| d | jksœt| jƒ‚| d | jks´t| jƒ‚|rÐ| d | jksÐt| jƒ‚d S )
Né )r rÞ r r r} r r r^ r ) r rˆ rd rÏ rÐ ÚladdrÚraddrrÙ rÉ )rå Zhas_pidrx rx ry Ú check_ntuple s z-check_connection_ntuple.<locals>.check_ntuplec S sð | j tttfkst| j ƒ‚td k r:t| j tjƒsNt| ƒ‚nt| j tƒsNt| ƒ‚| j tkrÌt | j | j
¡}t |¡R z|
| jd df¡ W n2 t jk
r¾ } z|jtjkr®‚ W 5 d }~X Y nX W 5 Q R X n | j tkrì| jtjksìt| jƒ‚d S )Nr )rÏ r r r‘ rˆ rÛ rñ rÜ rÓ rÈ rÐ rÆ rÇ rÉ rß Úerrorr Z
EADDRNOTAVAILrÙ r„ Ú CONN_NONE)rå rÖ r rx rx ry Ú check_family, s
z-check_connection_ntuple.<locals>.check_familyc S s† t tdtƒ ƒ}| jtjtj|fks,t| jƒ‚td k rLt| jtj ƒs`t| ƒ‚nt| jt
ƒs`t| ƒ‚| jtjkr‚| j t j
ks‚t| j ƒ‚d S )NÚSOCK_SEQPACKET)rŒ rÈ ÚobjectrÐ r rÕ rˆ rÛ rñ rÜ rÓ rÙ r„ rã )rå rå rx rx ry Ú
check_typeA s ÿÿ z+check_connection_ntuple.<locals>.check_typec S s¬ | j | jfD ]š}| jttfkr†t|tƒs4tt|ƒƒ‚|s:q t|j t
ƒsTtt|j ƒƒ‚d|j krjdksvn t|j ƒ‚t |j | jƒ q | jt
kr t|tƒs tt|ƒƒ‚q d S )Nr iÿÿ )rß rà rÏ r r rñ r– rˆ rÐ ZportrÓ rP Zipr‘ rò )rå rÑ rx rx ry Ú check_addrsM s "
z,check_connection_ntuple.<locals>.check_addrsc S s† t | jtƒst| jƒ‚dd„ ttƒD ƒ}| j|ks<t| jƒ‚| jttfkrl| j t
krl| jtj ks‚t| jƒ‚n| jtj ks‚t| jƒ‚d S )Nc S s g | ]}| d ¡rtt|ƒ‘qS )ZCONN_rŠ r rx rx ry r \ s
ÿzAcheck_connection_ntuple.<locals>.check_status.<locals>.<listcomp>) rñ rÙ rò rˆ rÏ r„ rÏ r r rÐ r rã )rå Zvalidsrx rx ry Ú check_statusZ s z-check_connection_ntuple.<locals>.check_statusNrx )rå rá rä rç rè ré rx rx ry Úcheck_connection_ntuple s
rê c C sP zddl }t|dƒst‚W n& tk
r@ ddl}| | ¡ Y S X | | ¡S dS )z,Backport of importlib.reload of Python 3.3+.r NÚreload)Ú importlibr! r‰ Úimprë )Úmodulerì rí rx rx ry rW p s
c C sœ t j t j | ¡¡d }tjd dkr:dd l}| || ¡S tjd d… dkrfddlm } ||| ƒ
¡ S dd l }|j
|| ¡}|j |¡}|j |¡ |S d S )Nr r} r )ÚSourceFileLoader)r~ r ÚsplitextrÒ r rƒ rí Z load_sourceZimportlib.machineryrï Ú load_moduleÚimportlib.utilÚutilÚspec_from_file_locationÚmodule_from_specÚloaderÚ exec_module)r rŸ rí rï rì ÚspecÚmodrx rx ry rX } s c C s t | t¡ dS )zRaise a warning msg.N)ÚwarningsrY Ú UserWarning)rb rx rx ry rY ’ s c C sV t | ƒ}|j}t|ƒdks&|d tkr*dS t|ddƒ}t|tƒsDdS tdd„ |D ƒƒS )z-Check if object is an instance of namedtuple.r r FÚ_fieldsNc s s | ]}t |ƒtkV qd S r¡ )rÐ rò )rŽ Únrx rx ry Ú <genexpr> s z is_namedtuple.<locals>.<genexpr>)rÐ Ú __bases__r r– rŒ rñ r§ )r ÚtÚbrë rx rx ry r[ — s
c # st t rdnd‰ d‰t| ˆ d}‡ ‡fdd„t ¡ ¡ D ƒ}t |¡}t ||¡ zt
|¡ |V W 5 t |ƒ X dS )zÂCtx manager which picks up a random shared CO lib used
by this process, copies it in another location and loads it
in memory via ctypes. Return the new absolutized path.
r{ r| z.sorF c s6 g | ].}t j |j¡d ˆkrˆ |j ¡ kr|j‘qS )r )r~ r rð Úlowerr ©rw Úextrx ry r s þú'copyload_shared_lib.<locals>.<listcomp>N) r" rJ r„ r… rh r r¡ r> rI rH ÚctypesZCDLL)rG ÚdstÚlibsrâ rx r ry rZ ¤ s
c # sÔ ddl m} ddl m} d‰ t| ˆ d}‡ fdd„t ¡ ¡ D ƒ}trb|sbdd„ t ¡ ¡ D ƒ}t |¡}t
||¡ d }zt |¡}|V W 5 |d k rÆt j j
j}|jg|_||jƒ}|dkrÆ|ƒ t|ƒ X d S )
zÖCtx manager which picks up a random shared DLL lib used
by this process, copies it in another location and loads it
in memory via ctypes.
Return the new absolutized, normcased path.
r )Úwintypes)ÚWinErrorz.dllrF c sF g | ]>}|j ¡ ˆ ¡rd tj |j ¡ ¡ krd|j ¡ kr|j ‘qS )r| Zwow64)r r rõ r~ rÒ r ©r rx ry r à s
ýr c S s( g | ] }d t j |j¡ ¡ kr|j‘qS )r{ )r~ r rÒ r r rx rx ry r È s ÿN)r r r
rJ r„ r… rh r" r r¡ r> rI ZwindllZkernel32Ú FreeLibraryZHMODULEZargtypesZ_handlerH ZWinDLL) rG r r
r r râ Úcfiler r8 rx r ry rZ ¸ s(
c C s t dd d S )NTr )r; rx rx rx ry Úcleanup_test_procså s r c C s
t | ¡S r¡ )r Úexit)r Úframerx rx ry rÜ ï rÝ rÜ )N)F)TF)N)r N)N)N)rÅ )rË )r )r )°r± Z
__future__r ÚatexitrÆ r r r¸ ri r¾ r~ r r" rà r> rý rÈ r: rs r rM rÐ r— r« rú r r r r„ r r r r r
r r Zpsutil._commonr
r r Zpsutil._compatr r r r r r r r rR Z unittest2r r‰ Úcatch_warningsÚ simplefilterrƒ rÛ Ú__all__Úbuiltin_module_namesr" rf r r\ r) Úmaxsizer, r! r r+ r rŸ r• r& r' Údecoder( r‘ r ZASCII_FSr r€ r® rC Ú__file__r$ r% ZHERErÖ r! r… r- r. r¼ r/ r1 r2 ZHAS_NET_IO_COUNTERSr3 r0 r4 r5 rH rm r6 rv r7 r8 Z HAS_THREADSÚgetuidZ SKIP_SYSCONSr‰ r# rè Údevnullr ÚregisterrÞ rÏ r* rŒ ræ r‘ rª rÇ rÔ r¨ r’ r» r< r> r= r9 rø rº r: r; rL rK r& rú rN rˆ rO rM rH rB ÚcontextmanagerrG rI rJ rN rC ZskipIfrB rF r¢ rD rE r¿ rA r? r@ rQ rR rS rT rU rV rP rê rW rX rY r[ rZ r rx rx rx ry Ú<module> sü
Ý-
ÿ
0 '
&-
X
%:
ÿ
ÿ ÿ
!
1
[
B
R
,
Back to Directory
File Manager