Ë
|
Iñúh;ý ã ó¬ d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
|
Z
|
ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddlm Z ddlm Z ddlm Z ddl Z ddl"Z"ddl"m#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+m0Z0 e(rddl1m2Z2 g d¢Z3dejh v Z5de
|
jl v xs de
|
jl v Z7e7Z8de
|
jl v Z9de
|
jl v Z:ejv dkD Z< e jz « j} « dv Z? e jz « d k( Z@e.d « ZAe%r eA« d kD ZB eA« d k\ ZCnd ZBd ZCd!ZDd"ZEd#ZFd$ZGe8reDd%z ZDeGd%z ZGeEd&z ZEeFd%z ZFe
|
j d'k( rd( e
|
j « d)ZJnd* e
|
j « d)ZJd+ZKd,j d-d.« ZM ej « j} « d/v ZOe
|
j j£ e
|
j j¥ e
|
j j§ eT« d0d0« « ZUe
|
jl j d1e
|
j j¥ eUd2« « ZWe
|
j j£ e
|
j j§ eT« « ZX eYe"j´ d3« Z[ eYe"j´ d4« Z\ eYe"d5« Z] eYe"j´ d6« Z^ eYe"j´ d7« Z_e(xr e) Z` eYe"d8« Za eYe"j´ d9« Zb eYe"j´ d:« Zc eYe"j´ d;« Zd eYe"d<« Ze eYe"d=« Zf eYe"d>« Zg eYe"j´ d?« Zhe%xs e#xr e
|
jÒ « dk7 Zj eexr ek e"jØ « « Zm eYe"d@« xr ek e"jæ « « ZtdA Zu eu« \ ZvZw exe
|
jò dB« Zz ejÞ ezjö « e|e"« D cg c] } | jû dC« s e~e"| « c} Z e~edD e« « Z e« Z e« Z G dE dF« Z
ee
j _n e #e
Z e
ej dG< e
j « G dH dIej « ZdJ ZeddK« ZedL « ZdM ZedN « ZedO « Zej$ eGfdPZddQZdR ZdS Z G dT dU« Z ee"j0 deGdV¬W« dX « Z eeefdeGdV¬W« ddY« Z eee j jÜ fdeGdV¬W« dZ « Zd[ Zd\ Zej> d] « Z d^ Z¡dd_Z¢dd`Z£ G da dbejH « Z¥e jL jO e5dc¬d« G de dfe¥« « Z¨dg Z©dh Zª G di dj« Z« G dk dl« Z¬eDfdmZddnZ®ddoZ¯d
dpZ°e e dfdqZ±ej> fdrZ²ddsZ³dt Z´ej> du « Zµdv Z¶dw Z·dx Z¸dy Z¹dz Zºd{ Z»d| Z¼e(rej> dd}« Z½nej> dd~« Z½ejÞ d « Z¾e(r ej" ej$ d « yy# e!$ r dZ Y Cw xY w# en$ r8 ejÞ ejà eq ejä « « « d ZmY *w xY w# en$ r8 ejÞ ejà eq ejä « « « d ZtY Gw xY wc c} w )zTest utilities.é N)ÚAF_INET)ÚAF_INET6)Ú SOCK_STREAM)ÚAIX)ÚLINUX)ÚMACOS)ÚNETBSD)ÚOPENBSD)ÚPOSIX)ÚSUNOS)ÚWINDOWS)Ú bytes2human)Údebug)Úmemoize)Ú print_color)Ú supports_ipv6)Úwait_pid)JÚDEVNULLÚGLOBAL_TIMEOUTÚTOLERANCE_SYS_MEMÚ
|
NO_RETRIESÚPYPYÚ
|
PYTHON_EXEÚPYTHON_EXE_ENVÚ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_TEMPERATURESÚHAS_NET_CONNECTIONS_UNIXÚ MACOS_11PLUSÚ MACOS_12PLUSÚCOVERAGEÚAARCH64ÚPYTEST_PARALLELÚpyrunÚ terminateÚ reap_childrenÚ spawn_subprocÚ spawn_zombieÚspawn_children_pairÚ
|
ThreadTaskÚunittestÚskip_on_access_deniedÚskip_on_not_implementedÚretry_on_failureÚTestMemoryLeakÚPsutilTestCaseÚprocess_namespaceÚsystem_namespaceÚis_win_secure_system_procÚ fake_pytestÚchdirÚ safe_rmpathÚ create_py_exeÚ create_c_exeÚ
|
get_testfnÚ
|
get_winverÚkernel_versionÚ
|
call_untilÚ wait_for_pidÚ wait_for_fileÚcheck_net_addressÚfilter_proc_net_connectionsÚ 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_namedtupleÚ__pypy__ÚGITHUB_ACTIONSÚ CIBUILDWHEELÚ COVERAGE_RUNÚPYTEST_XDIST_WORKERl > Úarm64Úaarch64Úriscv64c óB t j « d } t t t | j d« d d « « }|dk( rWt j t j dddgdd id
|
¬ « } t t t | j d« d d « « }|S ) Nr ú.é )é
|
é z-sSú-cz-import platform; print(platform.mac_ver()[0])ÚSYSTEM_VERSION_COMPATÚ0T)ÚenvÚuniversal_newlines)
|
ÚplatformÚmac_verÚtupleÚmapÚintÚsplitÚ
|
subprocessÚ check_outputÚsysÚ
|
executable)Ú version_strÚversions úHH:\Change_password\venv_build\Lib\site-packages\psutil/tests/__init__.pyÚ macos_versionr} z s ä×"Ñ"Ó$ QÑ'KÜC[× .Ñ .¨sÓ 3°B°QÐ 7Ó8Ó9GØ(Òô !×-Ñ-äØØØ?ð ð )¨#Ð.Ø #ô
|
ô C ×!2Ñ!2°3Ó!7¸¸Ð!;Ó<Ó=Ø Nó )ri é )é r Fri i P i é é é Újavaz$psutil-ú-z@psutil-u -ÆÅÅs fÀÚutf8Úsurrogateescape> úus-asciiÚasciiz..ÚPSUTIL_SCRIPTS_DIRÚscriptsÚ cpu_affinityÚenvironÚ
|
getloadavgÚioniceÚ memory_mapsÚnet_io_countersÚcpu_numÚ io_countersÚrlimitÚsensors_batteryÚ sensors_fansÚsensors_temperaturesÚthreadsÚcpu_freqc ó6 d } t j j « }t t dd « }t
|
r,t j dk\ r|t j |d< ||fS t rt j |fS t rÁ | t j « xs | t j j t j « « xsc | t j dj t j d d « « xs( | t j « j# « « }|s t% d« ||fS t j j t j « }t j j' |« sJ |« ||fS )Nc ó¦ t j | dgt j t j ¬« | S # t j $ r Y y w xY w)Nz-V)ÚstdoutÚstderr)rv Ú
|
check_callÚPIPEÚCalledProcessError)Úexes r| Úattemptz _get_py_exe.<locals>.attemptà sI ð Ü × !Ñ !Ød ¤J§O¡O¼J¿O¹Oõ ð Jøô ×,Ñ,ò Ùð ús 6: ºAÁAÚ_base_executable)r é Ú__PYVENV_LAUNCHER__z python{}.{}rh z"can't find python exe real abspath)Úosr ÚcopyÚgetattrrx r Ú version_infory r_ r ÚpathÚrealpathÚshutilÚwhichÚformatÚpsutilÚProcessr¡ Ú
|
ValueErrorÚexists)r¢ rn Úbaser¡ s r| Ú _get_py_exer´ ß sI òô **//Ó
|
Cô 3Ð*¨DÓ 1DÝ3×#Ñ# vÒ-°$Ð2Bô &)§^¡^Ð !Ñ"ØSyÐÝ Ü~~sÐ"Ð"Ý á CNNÓ #ò /Ùrww×'Ñ'¬¯©Ó7Ó8ò /áÜ Ð 1]× 1Ñ 1´3×3CÑ3CÀBÀQÐ3GÐ HÓIóò /ñ
|
v~~Ó'×+Ñ+Ó-Ó.ð ñ Ü Ð AÓBÐ BØCxägg× Ñ s~~Ó.Üww~~cÔ"Ð' CÓ'Ð"ØCxr~ zr+ÚSTATUS_ÚAF_UNIXc ó e Zd ZdZed « Zed « Zed d« Zed d« Zed d« Z ed d« Z
|
G d d
|
« Z y) rF zéA class that mimics some basic pytest APIs. This is meant for
|
when unit tests are run in production, where pytest may not be
|
installed. Still, the user can test psutil installation via:
|
|
$ python3 -m psutil.tests
|
c ó4 d } t j | « y )Nc ó< t j dt d¬« y )Nz<Fake pytest module was used. Test results may be inaccurate.é ©Ú
|
stacklevel©Úwarningsr[ Ú UserWarning© r~ r| Ú _warn_on_exitz0fake_pytest._warn_on_exit.<locals>._warn_on_exit' s Ü MMØNÜØ ö r~ )ÚatexitÚregister)rÁ s r| rÁ zfake_pytest._warn_on_exit% s ò ô Õ&r~ c ó t j « j t « }t j d¬« j |« |S )zMimics pytest.main(). It has the same effect as running
|
`python3 -m unittest -v` from the project root directory.
|
rh )Ú verbosity)r= Ú
|
TestLoaderÚdiscoverÚHEREÚTextTestRunnerÚrun)ÚargsÚkwÚsuites r| Úmainzfake_pytest.main0 s; ô
|
×#Ñ#Ó%×.Ñ.¬tÓ4Ü× Ñ ¨!Ô,×0Ñ0°Ô7Ø r~ Nc ó^ G d d« t j dfd « } || |¬« S )zMimics `pytest.raises`.c ó e Zd ZdZed « Zy)ú)fake_pytest.raises.<locals>.ExceptionInfoNc ó | j S ©N)Ú_exc©Úselfs r| Úvaluez/fake_pytest.raises.<locals>.ExceptionInfo.value@ s àyyÐ r~ )Ú__name__Ú
|
__module__Ú __qualname__rÔ Úpropertyr× rÀ r~ r| Ú ExceptionInforÑ = s ØDà ñ !ó ñ !r~ rÜ c 3 óÜ K « } | t | d« # | $ rF}|r3t j |t |« « sd| d| d}t |« ||_ Y d }~y d }~ww xY ww)Nz not raisedú"z" does not match ")ÚAssertionErrorÚreÚsearchÚstrrÔ )ÚexcÚmatchÚeinfoÚerrÚmsgrÜ s r| Úcontextz#fake_pytest.raises.<locals>.contextD sz øè ø á!OEð <Ø ô %¨ w¨kÐ%:Ó;Ð;øð ò !Ù¤§¡¨5´#°c³(Ô!;Ø eWÐ$6°s°e¸1Ð=CÜ(¨Ó-Ð-Ø
|
|
ûð !üs* A, A,A)£<A$Á A,Á$A)Á)A,)rä rÓ )Ú
|
contextlibÚcontextmanager)rã rä rè rÜ s @r| Úraiseszfake_pytest.raises9 s6 ø ÷ !ñ !ô
|
× "Ñ "ô
|
<ó
|
#ð
|
<ñ s %Ô(Ð(r~ c ó |r$t j « j | |« S t j « j | « S )zMimics `pytest.warns`.)r= ÚTestCaseÚassertWarnsRegexÚ assertWarns)Úwarningrä s r| Úwarnszfake_pytest.warnsS s= ñ Ü×$Ñ$Ó&×7Ñ7¸ÀÓGÐ GÜ× Ñ Ó"×.Ñ.¨wÓ7Ð7r~ c ó, t j | « )zMimics `unittest.SkipTest`.)r= ÚSkipTest©Úreasons r| Úskipzfake_pytest.skipZ s ô × Ñ Ó'Ð'r~ c óH t j « j | « S )zMimics `pytest.fail`.)r= rí Úfailrô s r| rø zfake_pytest.fail_ s ô × Ñ Ó"×'Ñ'¨Ó/Ð/r~ c ó2 e Zd Zedd« Z G d d« Zy)úfake_pytest.markc ó. t j | |« S )z'Mimics `@pytest.mark.skipif` decorator.)r= ÚskipIf)Ú conditionrõ s r| Úskipifzfake_pytest.mark.skipiff s ô ?? 9¨fÓ5Ð 5r~ c ó e Zd ZdZddZd Zy)ú fake_pytest.mark.xdist_groupz4Mimics `@pytest.mark.xdist_group` decorator (no-op).Nc ó y rÓ rÀ ©rÖ Únames r| Ú__init__z%fake_pytest.mark.xdist_group.__init__n s Ør~ c ó |S rÓ rÀ )rÖ Ú cls_or_meths r| Ú__call__z%fake_pytest.mark.xdist_group.__call__q s Ø"Ð"r~ rÓ )rØ rÙ rÚ Ú__doc__r r rÀ r~ r| Ú xdist_groupr k s Ù Fó ó #r~ r N©Ú )rØ rÙ rÚ Ú staticmethodrþ r rÀ r~ r| Úmarkrú d s à ò 6ó
|
ð 6÷ #ò #r~ r rÓ r
|
) rØ rÙ rÚ r r rÁ rÎ rë rñ rö rø r rÀ r~ r| rF rF s ñð ñ'ó ð'ð ñó ðð ò)ó ð)ð2 ò8ó ð8ð ò(ó ð(ð ò0ó ð0÷#ò #r~ rF Úpytestc óF e Zd ZdZ fdZd Zd Zd Zd Zd Z d Z
|
xZ S ) r< z6A thread task which does nothing expect staying alive.c óp t | « d| _ d| _ t j
|
« | _ y )NFçü©ñÒMbP?)Úsuperr Ú_runningÚ _intervalÚ threadingÚEventÚ_flag)rÖ Ú __class__s r| r zThreadTask.__init__ s* ø Ü ÑÔØ Ø Ü __Ó&
|
r~ c ón | j j }d| d| j dt | « ddS )Nú<z running=z at z#xú>)r rØ r Úidr s r| Ú__repr__zThreadTask.__repr__ s6 Ø~~×&Ñ&Ø4& $§-¡- °´R¸³X¸b°MÀÐCÐCr~ c ó& | j « | S rÓ )ÚstartrÕ s r| Ú __enter__zThreadTask.__enter__ s Ø
|
|
Ø r~ c ó$ | j « y rÓ )Ústop)rÖ rË Úkwargss r| Ú__exit__zThreadTask.__exit__ s Ø r~ c ó¤ | j r t d« t j j | « | j
|
j « y)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Õ s r| r zThreadTask.start s9 ð ==Ü Ð .Ó/Ð /Ü×Ñ× Ñ tÔ$Ø
|
|
Õr~ c ó¸ d| _ | j j « | j r-t j | j
|
« | j r,y y )NT)r r ÚsetÚtimeÚsleepr rÕ s r| rÊ zThreadTask.run¢ s7 Ø Ø
|
|
ÔØmmÜ JJt~~Ô &ð mmr~ c ó` | j s t d« d| _ | j « y)z8Stop thread execution and and waits until it is stopped.zalready stoppedFN)r r± ÚjoinrÕ s r| r" zThreadTask.stop¨ s% à}}Ü Ð .Ó/Ð /Ø Ø r~ ) rØ rÙ rÚ r r r r r$ r rÊ r" Ú __classcell__)r s @r| r< r<
s* ø Ù@ô'ò Dòòòò'ö r~ r< c óB t j « fd« }|S )Nc óF | i |¤S # t $ r t « w xY wrÓ )Ú Exceptionr8 )rË r# Úfuns r| Úwrapperz&_reap_children_on_err.<locals>.wrapper¶ s/ ø ð ÙÐ' Ñ'Ð 'øÜò Ü OØ ð ús ©Ú functoolsÚwraps)r2 r3 s ` r| Ú_reap_children_on_errr7 µ s% ø Ü__SÓóó ðð Nr~ c ó¨ |j dt « |j dt « |j dt j « « |j dt « t
|
rd}|j d|« | t t j « ¬« } t |« d| d }t d
|
|g} t j | fi |¤}t j |« t |d d ¬ « t |« |S t j | fi |¤}t j |« t |j « |S # t |« w xY w) a Create a python subprocess which does nothing for some 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 attempts to make sure the process is in a reasonably
|
initialized state.
|
The process is registered for cleanup on reap_children().
|
Ústdinr Úcwdrn é Ú creationflags©Údirzimport time;open(r'z6', 'w').close();[time.sleep(0.1) for x in range(100)];rk T©ÚdeleteÚempty)Ú
|
setdefaultr r¦ Úgetcwdr r rK rH r rv ÚPopenÚ_subprocesses_startedÚaddrP rO Úpid)ÚcmdÚkwdsÚCREATE_NO_WINDOWÚtestfnÚpylineÚsprocs r| r9 r9 Á s% ð OOGWÔ%ØOOHgÔ&ØOOE299;Ô'ØOOE>Ô*Ýð %ÐØ Ð)9Ô:Ø
|
{ܤ§ ¡ £ Ô,ð Ü Ô ðØ ð "9ð9ð ô
|
t VÐ,CÜ ×$Ñ$ SÑ1¨DÑ1EÜ !× %Ñ % eÔ ,Ü &¨°TÕ :ä Ô ð
|
Lô × Ñ Ñ-¨Ñ-Ü ×!Ñ! %Ô(ÜUYYÔ Ø Løô Õ ús Â"AE Å Ec ó> d} t t j « ¬« } t j dt j
|
j |« dt d« }t rt |d¬« \ }} nt |« \ }} t j |j « }t t |dd ¬
|
« « }t j! |« t j |« }||ft# |« | t# | « S S # t# |« | t# | « w w xY w) 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().
|
Nr= zl import subprocess, os, sys, time
|
s = "import os, time;"
|
s += "f = open('z¸', 'w');"
|
s += "f.write(str(os.getpid()));"
|
s += "f.close();"
|
s += "[time.sleep(0.1) for x in range(100 * 6)];"
|
p = subprocess.Popen([r'z.', '-c', s])
|
p.wait()
|
r )r< TFr? )rK r¦ rC ÚtextwrapÚdedentrª Úbasenamer r r6 r¯ r° rG rt rP Ú _pids_startedrF rH )ÚtfilerK ÚsÚsubpÚchildÚgrandchild_pidÚ
|
grandchilds r| r; r; ë s ð EÜ BIIKÔ (Fð Ü OOð ! ô WW× -Ñ -¨fÓ 5Ð 6ð 7%ô &0 Lð 1 ð ó õ Ü °Ô3KD%ä (KD%ÜtxxÓ(Ü ]¨6¸$ÀeÔ LÓMÜ×Ñ.Ô)Ü^^ NÓ3
|
ØzÐ"äFÔØ Ð Ü Õ ð øô FÔØ Ð Ü Õ ð ús ¢CD ÄD c óò t j sJ t « } t j d| d« }d}t | « } |j t « t |« \ }}|j « \ }} t j |j « gg g t « t |j d« « }t j |« t j |« t# fd« |f|j% « |j% « t' | « | t' |« S S # |j% « w xY w# |j% « t' | « | t' |« w w xY w)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
|
with socket.socket(socket.AF_UNIX) as s:
|
s.connect('za')
|
pid = bytes(str(os.getpid()), 'ascii')
|
s.sendall(pid)
|
Né c óF j « t j k( S rÓ )Ústatusr¯ Ú STATUS_ZOMBIE)Úzombies r| ú<lambda>z spawn_zombie.<locals>.<lambda>0 s ø v}}´&×2FÑ2FÑ F r~ )r¯ r rK rO rP rU Ú
|
settimeoutr r6 ÚacceptÚselectÚfilenort ÚrecvrR rF r° rN ÚcloserH ) Ú unix_fileÚsrcrS ÚsockÚparentÚconnÚ_Úzpidr^ s @r| r: r: s7 ø ô
|
<<Ð<Ü IÜ
|
//ð ð &;ð ' ð ó Cð EÜ IÓ &Dð Ø Ô'Ü c
|
Ø++-að Ü MM4;;=/¨2¨r´>Ô BÜtyy Ó'DÜ × Ñ dÔ #Ü^^ DÓ)FÜ ÓFÔ GØFÐ#à JJLà
|
|
ÜIÔ Ø Ð Ü Õ ð øð JJLûà
|
|
ÜIÔ Ø Ð Ü Õ ð ús% Á6E Á<B D6 Ã<E Ä6EÅE Å +E6c ó` |j dd« |j dd« t « } t |d« 5 }|j | « ddd« t t
|
j gfi |¤}t |j « ||fS # 1 sw Y >xY w# t $ r t |« w xY w)zRun python 'src' code string in a separate interpreter.
|
Returns a subprocess.Popen instance and the test file where the source
|
code was written.
|
r Nr Úw) rB rK ÚopenÚwriter9 r r rO rG r1 rH )rg rI ÚsrcfileÚfrU s r| r6 r6 ; s¡ ð OOHdÔ#ØOOHdÔ#ÜlGðÜ '3Ó ð 1Ø GGCL÷ ä j¨!¯&©&Ð 1Ñ:°TÑ:ÜTXXÔ ØgÐ ÷ ð ûô
|
ò ÜGÔ Ø ðús" ° B ¼B Á<B Â BÂB ÂB-c ó4 t rdnd}|j dt j « |j dt j « |j dd« |j d|« t | t
|
« rt j | « } t j | fi |¤}t j |« |j t ¬« \ }}|j dk7 rt ||z « |r t |« |j! d « r|d
|
d }|S ) zURun cmd in a subprocess and return its output.
|
raises RuntimeError on error.
|
r; r r r ro Tr< ©Útimeoutú
|
Néÿÿÿÿ)r rB rv r Ú
|
isinstancerâ Úshlexru rD rE rF Ú communicater Ú
|
returncodeÚ RuntimeErrorr[ Úendswith)rH rI ÚflagsÚpr r s r| Úshr O sÞ õ !I aEØOOHjooÔ.ØOOHjooÔ.ØOOÐ(¨$Ô/ØOOO UÔ+Ü#sÔÜkk#Ó Ü×ÑÑ% Ñ%AÜ× Ñ aÔ Ø]]¬>]Ó:NFFØ||qÒÜ6 F?Ó+Ð+Ù Ü V Ø tÔ ØØ Mr~ c ó¬
|
d
|
d
|
fd}
|
fd fd}d }| } t |t « ru |||« t |t j t j f« r ||« t |t « r|n |j
|
}t j |« rJ |« S t |t j t j f« ru ||« t |t j t j f« r ||« t |t « r|n |j
|
}t j |« rJ |« S t |t j « ru |||« t |t j t j f« r ||« t |t « r|n |j
|
}t j |« rJ |« S t d|« # t |t j t j f« r ||« t |t « r|n |j
|
}t j |« rJ |« w xY w)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.
|
c óø | j |« t rJt | t j « r/ t j | j « j |« S y y # t
|
j $ r Y y w xY wrÓ ) r' r rx rv rD r¯ r° rG Ú NoSuchProcess)Úprocru s r| r' zterminate.<locals>.waits sd Ø 'ÔÝ z $¬
|
×(8Ñ(8Ô9ð Ü ~~ d§h¡hÓ/×4Ñ4°WÓ=Ð=ð :7øô ×'Ñ'ò Ùð ús ³-A# Á#A9Á8A9c óÎ t rt rt j }t r2|t j k7 r | j t j « | j |« y rÓ )r r_ ÚsignalÚSIGKILLr Ú send_signalÚSIGCONT)r Úsigs r| Úsendsigzterminate.<locals>.sendsig| s@ å ^Ü..Cõ SFNNÒ*Ø × Ñ V^^Ô ,Ø ×ÑÕ r~ c ó | « | |« S # t $ r Y t $ r }t r|j dk( r d }~ww xY w)Né )ÚProcessLookupErrorÚOSErrorr Úwinerror)r ru ræ r r r' s r| Úterm_subprocess_procz'terminate.<locals>.term_subprocess_proc sR ø ð Ù D#Ô ñ D'Ó"Ð"øô "ò Ù Üò Ý3<<¨1Ò,ØØ ûð ús A A¨?¿Ac ó\ | « | |« S # t j $ r Y w xY wrÓ )r¯ r )r ru r r r' s r| Úterm_psutil_procz#terminate.<locals>.term_psutil_proc s; ø ð Ù D#Ô ñ D'Ó"Ð"øô ×#Ñ#ò Ù ð ús +ª+c ó t j | « } ||« S # t j $ r t rt | |« cY S Y y w xY wrÓ )r¯ r° r r r )rG ru r r s r| Úterm_pidzterminate.<locals>.term_pid sQ ø ð 3Ü>> #Ó&Dñ $ D¨'Ó2Ð 2øô ×#Ñ#ò .åÜ WÓ-Ò-ñ ð .ús ! ¡%A Á
|
A c óê | j r| j j « | j r| j j « | j r| j j « y y rÓ )r re r r9 )r s r| Ú flush_popenz terminate.<locals>.flush_popen¢ sL Ø ;;Ø KK× Ñ Ô Ø ;;Ø KK× Ñ Ô à ::Ø JJ× Ñ Õ ð r~ z wrong type ) rx rt rv rD r¯ rG Ú
|
pid_existsr° Ú TypeError) Ú proc_or_pidr Ú wait_timeoutr r r r rG r r r' s ` @@@r| r7 r7 h sÜ û òò ö #ö#ô3ò ð Að /Ü aÔ ÙA|Ó,ô a*×*Ñ*¬F¯L©LÐ9Ô :Ù NÜ a¤Ô%a¨1¯5©5Ü×$Ñ$ SÔ)Ð.¨3Ó.Ð)Ð)ô FNN¬F¯L©LÐ9Ô :Ù# A |Ó4ô a*×*Ñ*¬F¯L©LÐ9Ô :Ù NÜ a¤Ô%a¨1¯5©5Ü×$Ñ$ SÔ)Ð.¨3Ó.Ð)Ð)ô :×+Ñ+Ô ,Ù'¨¨<Ó8ô a*×*Ñ*¬F¯L©LÐ9Ô :Ù NÜ a¤Ô%a¨1¯5©5Ü×$Ñ$ SÔ)Ð.¨3Ó.Ð)Ð)ô k¨!¨Ð /Ó0Ð 0øä a*×*Ñ*¬F¯L©LÐ9Ô :Ù NÜ a¤Ô%a¨1¯5©5Ü×$Ñ$ SÔ)Ð.¨3Ó.Ð)Ð)ús ¤G% Â)2G% Å"G% ÇG% Ç%A.Ic óÈ t j « j | ¬« }t r&t j « }t |« t r&t r&t j « }t |« t r&|rd|D ] }t |d¬« t j |t ¬« \ }}|D ], }t d|d« t |t j ¬« . yy)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 recursive is True it also tries to terminate and wait()
|
all grandchildren started by this process.
|
©Ú recursiveN)r rt zcouldn't terminate process z; attempting kill())r ) r¯ r° ÚchildrenrE Úpopr7 rR Ú
|
wait_procsr r[ r r )r r rU rG r rk Úalives r| r8 r8 ¼ sÅ ô ~~Ó ×(Ñ(°9Ð(Ó=Hõ Ü$×(Ñ(Ó*Ü$ö õ
|
Ü× Ñ Ó!Ü#ö ñ
|
Øò ,AÜ a dÖ +ð ,ä×$Ñ$ X´~ÔF5Øò -AÜ Ð.¨q¨eÐ3FÐGÔ HÜ aV^^Ö ,ñ -ð r~ c ó| t s t d« d} t j « d }|D ] }|j « s|dk( r| |z } n | st d|« d}d}| j d« }t |d « }t |« dk\ rt |d « }t |« dk\ rt |d « }|||fS ) z"Return a tuple such as (2, 6, 36).z not POSIXr rh rg z can't parse r rº r ) r ÚNotImplementedErrorr¦ ÚunameÚisdigitr± ru rt Úlen)rT r¥ ÚcÚminorÚmicroÚnumsÚmajors r| rM rM á sÆ å Ü! +Ó.Ð.Ø
|
AÜ HHJqMEØ ò Ø 99;!s(Ø FAá ð ñ
|
Ü<¨ yÐ1Ó2Ð2Ø EØ EØ 773<DÜ QLEÜ
|
4yA~ÜDG Ü
|
4yA~ÜDG Ø 5%Ð Ð r~ c ó t s t d« t j « } | j xs d}| d | d |fS )Nz not WINDOWSr rº )r r¤ rx ÚgetwindowsversionÚservice_pack_major)ÚwvÚsps r| rL rL ù sC Ý Ü! -Ó0Ð0Ü × Ñ Ó BØ × Ñ Ò # !BØ qE2a5"Ð Ð r~ c ó4 e Zd ZdZeddddfdZd Zd Zd Zy)ÚretryzA retry decorator.Nr c óh |r |r t d« || _ || _ || _ || _ || _ y )Nz/timeout and retries args are mutually exclusive)r± Ú exceptionru ÚretriesÚintervalÚlogfun)rÖ rµ ru r¶ r· r¸ s r| r zretry.__init__ s8 ñ wÜ Ð NÓOÐ OØ"Ø Ø Ø Ø r~ c # ó0 K | j rVt j « | j z }t j « |k r d t j « |k r y y | j r t | j « D ] }d y d wrÓ )ru r* r¶ Úrange)rÖ Ústop_atrk s r| Ú__iter__zretry.__iter__ sq è ø Ø <<Üiik D§L¡LÑ0GÜ))+ Ò'Ûô ))+ Õ'à \\Ü4<<Ó(ò Üñ ð Ûð ùs A BÁ#3Bc ó\ | j t j | j « y y rÓ )r· r* r+ rÕ s r| r+ z retry.sleep% s! Ø ==Ð $Ü JJt}}Õ %ð %r~ c óT t j « fd« } |_ |S )Nc óÄ d }D ] } | i |¤c S |# j $ r9}|}j j |« j « Y d }~Td }~ww xY wrÓ )rµ r¸ r+ )rË r# rã rk r2 rÖ s r| r3 z retry.__call__.<locals>.wrapper* sp ø àCØò ð Ù Ð/¨Ñ/Ò/ð ð Iøð ~~ò ØCØ{{Ð.Ø CÔ(ØJJLÜ ûð ús A ¦/AÁA )r5 r6 Ú decorator)rÖ r2 r3 s `` r| r zretry.__call__) s- ù Ü Ó ô ó
|
ð ð !ÔØr~ ) rØ rÙ rÚ r r1 r r¼ r+ r rÀ r~ r| r³ r³ s* Ù ð ØØØØó ò
|
ò&ór~ r³ r )rµ r¸ ru r· c ó | t j « vrt j | « t j | « y)zWait for pid to show up in the process list then return.
|
Used in the test suite to give time the sub process to initialize.
|
N)r¯ Úpidsr r° )rG s r| rO rO ? s/ ð &++-Ñ Ü×"Ñ" 3Ó'Ð'Ü
|
NN3Õr~ c ó t | d« 5 }|j « }ddd« |ssJ |r t | « S # 1 sw Y xY w)z8Wait for a file to be written on disk with some content.ÚrbN)ro ÚreadrH )Úfnamer@ rA rr Údatas r| rP rP N sJ ô
|
eTÓ ð aØvvx÷á Ù tÙ ÜEÔØ K÷ ð ús ;»Ac ó | « }|sJ |S )z1Keep calling function until it evaluates to True.rÀ )r2 Úrets r| rN rN _ s ñ %CÙ J3Ø Jr~ c óP d } t j | « }t j |j « r%t j
|
t j | « }n$t j
|
t j | « }t r |« y ||« y# t $ r Y yw xY w)z?Convenience function for removing temporary test files or dirs.c ó6 t j « t z }t j « |k r | « S # t $ r Y n%t $ r}|}t d| « Y d }~nd }~ww xY wt j
|
d« t j « |k rg`)Nz ignoring g{®Gáz?)r* r ÚFileNotFoundErrorr r[ r+ )r2 r» rk ræ s r| Ú retry_funz safe_rmpath.<locals>.retry_funt s ô
|
))+¤Ñ.ÜiikGÒ#ð (Ùu ð øô %ò ÙÜò (ØÜy Ð&×'Ñ'ûð (úô JJtÔ ô iikGÓ#øs ´= ½ A*ÁA*ÁA%Á%A*N) r¦ ÚstatÚS_ISDIRÚst_moder5 Úpartialr¬ ÚrmtreeÚremover rÌ )rª rÍ Ústr2 s r| rH rH q sv òð" Ü WWT]Ü <<
|
|
Ô #Ü×#Ñ#¤F§M¡M°4Ó8Cä×#Ñ#¤B§I¡I¨tÓ4CÝ Ù Eá cNøÜ ò Ù ð ús
B
|
B ÂB Â B%Â$B%c óN t j | « y# t $ r Y yw xY w)z.Convenience function for creating a directory.N)r¦ ÚmkdirÚFileExistsErrorr= s r| Ú
|
safe_mkdirrØ s$ ð Ü
|
øÜ ò Ù ð ús $£$c # óÆ K t j « } t j | « d t j |« y# t j |« w xY ww)z@Context manager which temporarily changes the current directory.N)r¦ rC rG )ÚdirnameÚcurdirs r| rG rG s? è ø ô YY[FðÜ
|
ÔÛ ä
|
ÕøÕüs A!A ±A!ÁA Á A!c óR t j j | « rJ | « t j t
|
| « t j t | « t rFt j | « }t j | |j t j z « | S )z6Create a Python executable file in the given location.)r¦ rª r² r rà rH r¬ Úcopyfiler r rÎ ÚchmodrÐ ÚS_IEXEC)rª rÔ s r| rI rI ¦ si äww~~dÔ#Ð) TÓ)Ð #Ü
|
OOK Ô&Ü
|
OOJ Ô%Ý Ü WWT]Ü
|
rzz¤D§L¡LÑ0Ô1Ø Kr~ c óV t j j | « rJ | « t j d« st j d« S |t j d« }nt |t « sJ |« t j t | « t t d¬« d« 5 }|j! |« ddd« t# j$ dj& d| g« t |j& « | S # 1 sw Y DxY w# t j& « w xY w) z5Create a compiled C executable in the given location.Úgcczgcc is not installedNz
|
#include <unistd.h>
|
int main() {
|
pause();
|
return 1;
|
}
|
z.c©Úsuffixrn z-o)r¦ rª r² r¬ r r rö rO rP rx râ r rà rH ro rK rp rv r r )rª Úc_coderr s r| rJ rJ ± sç äww~~dÔ#Ð) TÓ)Ð #Ü <<Ô Ü{{Ð1Ó2Ð2Ø ~Ü ð "ó ô &¤#Ô&Ð.¨Ó.Ð&ä
|
OOK Ô&Ü j Ô% sÓ +ð ¨qØ ÷ð Ü× Ñ u a§f¡f¨d°DÐ 9Ô:äAFFÔØ K÷ ð ûô
|
AFFÕús Â0Dà #D ÄDÄD(c óò t j t | |¬« }t j j |« s;t j j |« }t j t |« |S w)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.
|
)Úprefixrã r> )
|
ÚtempfileÚmktempr r¦ rª r² r« r rà rH )rã r> r rª s r| rK rK Ë sU ð ܤm¸FÈÔLÜww~~dÔ#Ü77×#Ñ# DÓ)DÜ OOK¨Ô .ØKð r~ c óT e Zd ZdZd ZddZd Zd Zd Zd Z d Z
|
d
|
Z d Z d Z d Zy)rB zTest class providing auto-cleanup wrappers on top of process
|
test utilities. All test classes should derive from this one, even
|
if we use pytest.
|
c ó¼ | j j }|j d« sd|z }dj || j j | j
|
« S )Nzpsutil.z psutil.tests.z{}.{}.{})r rÙ Ú
|
startswithr® rØ Ú_testMethodName)rÖ Úfqmods r| Ú__str__zPsutilTestCase.__str__ç sU Ø×)Ñ)Ø× Ñ Ô*Ø# eÑ+EØ× Ñ Ø Ø NN× #Ñ #Ø × Ñ ó
|
ð
|
r~ Nc óL t ||¬« }| j t |« |S )N)rã r> )rK Ú
|
addCleanuprH )rÖ rã r> rÆ s r| rK zPsutilTestCase.get_testfnñ s! Ü &¨cÔ2Ø UÔ+Ø r~ c óH t |i |¤}| j t |« |S rÓ )r9 rð r7 )rÖ rË rI rM s r| r9 z PsutilTestCase.spawn_subprocö s$ Ü tÐ, tÑ,Ø 5Ô)Ø r~ c óÌ | j |i |¤} t j |j « S # t j $ r | j |j « w xY wrÓ )r9 r¯ r° rG r Úassert_pid_gone)rÖ rË r# rM s r| Ú spawn_psproczPsutilTestCase.spawn_psprocû s[ Ø"×"Ñ" DÐ3¨FÑ3ð Ü>> %§)¡)Ó,Ð ,øÜ×#Ñ#ò Ø × Ñ §¡Ô +Ø ð ús 3 ³0A#c ó| t « \ }}| j t |« | j t |« ||fS rÓ )r; rð r7 )rÖ Úchild1Úchild2s r| r; z"PsutilTestCase.spawn_children_pair s5 Ü,Ó.Ø 6Ô*Ø 6Ô*ØÐ Ð r~ c ó| t « \ }}| j t |« | j t |« ||fS rÓ )r: rð r7 )rÖ ri r^ s r| r: zPsutilTestCase.spawn_zombie s4 Ü% Ø 6Ô*Ø 6Ô*ØÐ Ð r~ c óz t |i |¤\ }}| j t |« | j t |« |S rÓ )r6 rð rH r7 )rÖ rË rI rM rq s r| r6 zPsutilTestCase.pyrun s6 Ü Ð-¨Ñ-wØ WÔ-Ø 5Ô)Ø r~ c ó¬ t |t j « sJ |j |j k( sJ |j |j
|
k( sJ |j r|j sJ t |t j « r8|j |j k( sJ |j |j dk\ sJ t |« t |« y ©Nr ) rx r¯ ÚErrorrG r Ú_nameÚ ZombieProcessÚppidÚ_ppidrâ Úrepr)rÖ r rã s r| Ú_check_proc_excz PsutilTestCase._check_proc_exc s¢ Ü#v||Ô,Ð,Ð,Øww$((Ò"Ð"Ð"Øxx4::Ò%Ð%Ð%Ø 88Ø88O8Ü c6×/Ñ/Ô 0Ø88tzzÒ)Ð )Ð)ØxxÐ#Øxx 1}Ð$}Ü CÜ S r~ c óH t j t j « 5 } t j |« d d d « j j |k( sJ |j j J t j |« rJ |« |t j « vsJ |t j « D cg c] }|j c}vsJ y # t j
|
$ r! t j d« cY cd d d « S w xY w# 1 sw Y ØxY wc c}w )Nz&wasn't supposed to raise ZombieProcess) r rë r¯ r r° rþ rø r× rG r r rÂ Ú process_iter)rÖ rG ÚcmÚxs r| ró z PsutilTestCase.assert_pid_gone" sú Ü ]]6×/Ñ/Ó 0ð M°Bð MÜsÕ#÷ Mð
|
xx||sÒ"Ð"Ð"Øxx}}Ð$Ð$Ð$Ü×$Ñ$ SÔ)Ð.¨3Ó.Ð)Ø&++-Ñ'Ð'Ð'ج&×*=Ñ*=Ó*?Ö@ Q155Ò@Ñ@Ð@Ñ@øô ×'Ñ'ò MÜ {{Ð#KÓLÑL÷ Mñ Mð Mú÷ Mð Müò As. ¤D¦C ÃD à (DÄDÄDÄDÄD c óâ | j |j « t |« }|j |j d¬« D ]< \ }}| j t |« |¬« 5 |« }d| d|}t |« |j d¬« y # t j $ r t j $ r }| j ||« Y d }~nd }~ww xY w d d d « ¡# 1 sw Y ªxY w)NT©Ú clear_cache©r r zProcess.z!() didn't raise NSP and returned r rt ) ró rG rC ÚiterÚallÚsubTestrâ rß r¯ rþ r r r' )rÖ r Únsr2 r rÉ rç rã s r| Úassert_proc_gonez PsutilTestCase.assert_proc_gone. sð Ø × Ñ TXXÔ&Ü tÓ $Ø §¡°TÓ:ò .ICØ ¤3 t£9°4 Ó8ñ .ð .Ù %Cð # 4 &ð ) Ø 7ð$ð ô )¨Ó-Ð-ð .ð ! Õ øô ×+Ñ+ò ØÜ ×+Ñ+ò 4Ø×(Ñ(¨¨s×3Ñ3ûð4úØ3÷ .÷ .ñ .ús6 Á&C%Á(BÁ/C%Â&CÂ<CÃC%ÃCÃC%Ã%C. c óÊ t j |j « }||k( sJ t s%t s t
|
st |« t |« k( sJ |j « t j k( sJ |j « sJ t j |j « sJ |j « |j t j « v sJ |j t j « D cg c] }|j c}v sJ i t _ |j t j « D cg c] }|j c}v sJ t |« }|j! |j" d¬« D ]2 \ }}| j% t' |« |¬« 5 |« d d d « 4 t. rt1 j2 t j( « 5 }|j5 « d d d « | j- |j6 « t1 j2 t j( « 5 }|j9 « d d d « | j- ||j6 « t1 j2 t j( « 5 }|j; « d d d « | j- ||j6 « |j= « |j? « |jA « |jC « |j « sJ t j |j « sJ |j t j « v sJ |j t j « D cg c] }|j c}v sJ i t _ |j t j « D cg c] }|j c}v sJ y c c}w c c}w # t j( t j* f$ r }| j- ||« Y d }~sd }~ww xY w# 1 sw Y °xY w# 1 sw Y ExY w# 1 sw Y úxY w# 1 sw Y ¯xY wc c}w c c}w )NTr r
|
)"r¯ r° rG r
|
r r Úhashr\ r] Ú
|
is_runningr Úas_dictr r Ú_pmaprC r r r râ rþ Ú AccessDeniedr r r rë Úcmdliner× r¡ r ÚsuspendÚresumer7 Úkill) rÖ r Úcloner r r2 r rã r s r| Úassert_proc_zombiez!PsutilTestCase.assert_proc_zombieA sE ätxxÓ(ð
|
u}Ð }Ý6¥UÜ:¤ e£Ò,Ð ,Ð,à{{}¤× 4Ñ 4Ò4Ð4Ð4àÔ Ð Ð Ü× Ñ §¡Ô*Ð*Ð*à àxx6;;=Ñ(Ð(Ð(Øxx¬6×+>Ñ+>Ó+@ÖA aAEEÒAÑAÐAÐAØ Øxx¬6×+>Ñ+>Ó+@ÖA aAEEÒAÑAÐAÐAä tÓ $Ø §¡°TÓ:ò 4ICØ ¤3 t£9°4 Ó8ñ 4ð4ÙE÷ 4ð 4ð 4ö ä v× 3Ñ 3Ó4ð ¸Ø ÷ à × Ñ r§x¡xÔ 0Ü v× 3Ñ 3Ó4ð ¸Ø
|
÷ à × Ñ r§x¡xÔ 0Ü v× 3Ñ 3Ó4ð #¸Ø× Ñ Ô"÷ #à × Ñ r§x¡xÔ 0à Ø Ø ÔØ ØÔ Ð Ð Ü× Ñ §¡Ô*Ð*Ð*Øxx6;;=Ñ(Ð(Ð(Øxx¬6×+>Ñ+>Ó+@ÖA aAEEÒAÑAÐAÐAØ Øxx¬6×+>Ñ+>Ó+@ÖA aAEEÒAÑAÐAÑAùòA BùâAøô ×,Ñ,¬f×.AÑ.AÐBò 4Ø×(Ñ(¨¨s×3Ò3ûð4ú÷ 4ñ 4ú÷ ñ ú÷ ñ ú÷ #ñ #üò BùâAsl Ã;OÅ O Æ#P'Æ%O$Ç P4È8QÊQÍ;QÏ Q Ï$#P$ÐP ÐP'Ð P$Ð$P'Ð'P1 Ð4P>ÑQ ÑQ©r N)rØ rÙ rÚ r rî rK r9 rô r; r: r6 r ró r r rÀ r~ r| rB rB Þ s@ ñò
|
óò
|
ò
|
ò ò ò ò ò
|
Aò ó&3Br~ rB zunreliable on PYPYrô c óØ e Zd ZdZdZdZdZerdndZdZ e
|
j « Z e ej d« « Zed « Zed « Zd
|
Zd Zd Zd Zd Zd Zd Z ddZd Z y)rA 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)
|
éÈ ri r r TÚ PSUTIL_DEBUGc ó. t j d« y )NF)r¯ Ú
|
_set_debug©Úclss r| Ú
|
setUpClasszTestMemoryLeak.setUpClass® s ä×Ñ%Õ r~ c óB t j | j « y rÓ )r¯ r! Ú_psutil_debug_origr" s r| Ú tearDownClassz TestMemoryLeak.tearDownClass² s ä×Ñ#×0Ñ0Õ1r~ c ód | j j « }t |d|j « S )NÚuss)Ú _thisprocÚmemory_full_infor¨ Úrss)rÖ Úmems r| Ú_get_memzTestMemoryLeak._get_mem¶ s) ð nn×-Ñ-Ó/ÜsE 3§7¡7Ó+Ð+r~ c óv t r| j j « S | j j « S rÓ )r r* Únum_fdsÚ num_handlesrÕ s r| Ú _get_num_fdszTestMemoryLeak._get_num_fds¼ s+ Ý Ø>>×)Ñ)Ó+Ð +à>>×-Ñ-Ó/Ð /r~ c óV | j r t |dt j ¬« y y )NÚyellow)ÚcolorÚfile)Úverboser rx r )rÖ rç s r| Ú_logzTestMemoryLeak._log s Ø <<Ü 8´#·*±*Ö =ð r~ c ó | j « }| j |« | j « }||z
|
}|dk rd|d}t j |« S |dkD r3t rdnd}|dkD r|dz }| d| d |}t j |« S y
|
) 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 znegative diff z8 (gc probably collected a resource from a previous test)ÚfdÚhandlerº rT z
|
unclosed z after calling N)r2 Úcallr rø r )rÖ r2 ÚbeforeÚafterÚdiffrç Útype_s r| Ú
|
_check_fdszTestMemoryLeak._check_fdsÆ s¬ ð
|
×"Ñ"Ó$Ø #Ø×!Ñ!Ó#Øv~Ø !8à ð )2ð 2ð ô ;;sÓ#Ð #Ø !8Ý !D xEØaxØ ØF* U G¨?¸3¸'ÐBCÜ;;sÓ#Ð #ð r~ c ó t j d¬« | j « }t |« D ] }| j |« }~~ t j d¬« | j « }t j
|
g k( sJ ||z
|
}|S )zGet 2 distinct memory samples, before and after having
|
called fun repeatedly, and return the memory difference.
|
rº )Ú
|
generation)ÚgcÚcollectr. rº r< Úgarbage)rÖ r2 ÚtimesÚmem1r rÉ Úmem2r? s r| Ú _call_ntimeszTestMemoryLeak._call_ntimesÜ sy ô
|
|
aÕ Ø}}Üu ò AØ))C.CØ3ð ô
|
|
aÕ Ø}}ÜzzRÒ Ð Ð Ød{Ø r~ c ó° g }d}|}t d|dz « D ] }| j ||« } dj |t | « t | |z « |« }
|
|j |
|
« | |k xs | |k } | r|dkD r| j |
|
« y |dk( r
|
t « | j |
|
« ||z }| } t j dj |« « S )Nr rº z,Run #{}: extra-mem={}, per-call={}, calls={}z. )
|
rº rJ r® r Úappendr8 Úprintr rø r- ) rÖ r2 rG r¶ Ú toleranceÚmessagesÚprev_memÚincreaseÚidxr- rç Úsuccesss r| Ú
|
_check_memzTestMemoryLeak._check_memë sà ØØØÜG aKÓ(ò CØ×#Ñ# C¨Ó/CØ@×GÑGØÜCÓ ÜC %KÓ(Øó Cð OOCÔ ØYÑ&Ò9¨#°©/GÙØ7ØIIcNÙà!8ÜGØ #ØÑ!Ø ð' ô( {{499 XÓ.Ó/Ð/r~ c ó |« S rÓ rÀ )rÖ r2 s r| r< zTestMemoryLeak.call s Ùu r~ Nc ó¢ ||n | j }||n | j }||n | j }||n | j } |dk\ sJ d« |dk\ sJ d« |dk\ sJ d« |dk\ sJ d« | j ||« | j |« | j ||||¬« y# t $ r}t t |« « d}~ww xY w) zTest a callable.Nrº ztimes must be >= 1r zwarmup_times must be >= 0zretries must be >= 0ztolerance must be >= 0)rG r¶ rN )
|
rG Ú warmup_timesr¶ rN rß r± râ rJ rA rT )rÖ r2 rG rW r¶ rN ræ s r| ÚexecutezTestMemoryLeak.execute
|
sí ð Ð*°·
|
±
|
à (Ð 4L¸$×:KÑ:Kð ð %Ð 0'°d·l±lØ!*Ð!6I¸D¿N¹N ð 'ØA:Ð 3Ð 3Ó 3:Ø 1Ò$Ð AÐ&AÓ AÐ$Øa<Ð 7Ð!7Ó 7<Ø >Ð ;Ð#;Ó ;>ð ×Ñ#|Ô,Ø Ô Ø 5°'ÀYÕOøô ò 'Ü S XÓ&Ð &ûð 'ús Á0B, Â, CÂ5C à Cc ó: fd} | j |fi |¤ y)znConvenience method to test a callable while making sure it
|
raises an exception on every call.
|
c ó^ « t j d « S # $ r Y y w xY w)Nz did not raise )r rø )rã r2 s r| r< z*TestMemoryLeak.execute_w_exc.<locals>.call% s> ø ð AÙô {{ c U¨/¸#¸Ð#?Ó@Ð@øð ò Ùð ús $ ¤,«,N)rX )rÖ rã r2 r# r< s `` r| Ú execute_w_excz TestMemoryLeak.execute_w_exc s ù õ
|
Að TÑ$VÓ$r~ )NNNN) rØ rÙ rÚ r rG rW rN r r¶ r7 r¯ r° r* Úboolr¦ Úgetenvr& Ú classmethodr$ r' r. r2 r8 rA rJ rT r< rX r[ rÀ r~ r| rA rA
s¥ ñ ð> EØLØIÙ b AGØGØ Ó IÙ ibii¨Ó 7Ó8Ðàñ!ó ð!ð ñ2ó ð2ò,ò 0ò >ò$ò, ò 0ò8ð KOóPó, %r~ rA c óT t d « } |« | dk( S # t $ r Y yw xY w)Nc óæ i } t d« }|j « dd D ]H }|j d« D cg c] }|j dd« }}|d t |d « }}|| |< J | S c c}w )Nztasklist.exe /NH /FO csvrº ú,rÞ r r )r Ú
|
splitlinesru Úreplacert )rÉ ÚoutÚliner Úbitsr rG s r| Ú get_procsz,is_win_secure_system_proc.<locals>.get_procs2 s àÜÐ+Ó,ØNNÓ$ Q RÐ(ò DØ04·
|
±
|
¸3³Ö@¨1AIIc 2Õ&Ð@DÐ@Ø Q¤ T¨!¡W£ #DØCHð ð
|
ùò As ·A.z Secure SystemF)r ÚKeyError)rG rg s r| rE rE 0 s= ä ñó ððÙ{3Ñ ?Ñ2Ð2øÜ ò Ùðús '¦'c óÂ t j « } t | d« r| j « S t | d« r#t j
|
| j « « S y)Nr r r )r¯ r° Úhasattrr ÚrandomÚchoicer )r s r| Ú_get_eligible_cpurm B sG ÜÓAÜq)Ô Øyy{ÐÜ NÔ #Ü}}Q^^Ó -Ó.Ð.Ø r~ c óì e Zd ZdZddi fddi fgZddi fddddifd di fd
|
di fd di fd di fd di fddi fddi fg Zddi fddi fddi fddi fddi fddi fddi fddi fddddifd di fd di fd di fd di fd di fd!di fd"di fd#di fgZer$ed$di fgz Zed%di fgz Zed&di fgz Zed'di fgz Zer ed(di fgz Ze r ed)di fgz Ze
|
red*e j fi fgz Ze r ed+di fgz Zer ed,di fgz Zer ed-di fgz Zer ed.di fgz Zer ed/dd0d1ifgz Zg Zer
|
ed di fgz Zned e j& fi fgz Ze
|
red*e j d2fi fgz Ze r,ered)e j* d3fi fgz Zned)e j, fi fgz Ze red+ e« gfi fgz Zd4ej2 fi fd5di fd6di fd7di fd8di fgZer(ed4ej6 fi fgz Zed4ej8 fi fgz Zeez ez ez Z d9 Z d?d:Z d; Z e!d< « Z"e!d= « Z#y>)@rC 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_percentrÀ Úmemory_percentr r r TÚ connectionsr Úoneshotri ÚparentsrG r' )r r Ú cpu_timesÚ create_timer: r¡ r+ Ú memory_infor Únet_connectionsÚkindr ÚniceÚnum_ctx_switchesÚ num_threadsÚ
|
open_filesrÿ r\ r ÚusernameÚuidsÚgidsÚterminalr0 r r r r r r r1 r ÚgroupedF)rZ i r r r r r7 r c ó || _ y rÓ )Ú_proc)rÖ r s r| r zprocess_namespace.__init__¨ s Ø
|
r~ c # óð K t |« }t j |« |D ]M \ }}}|r| j « t | j
|
|« }t j |g|¢i |¤}||f O yw©z_Given a list of tuples yields a set of (fun, fun_name) tuples
|
in random order.
|
N)Úlistrk Úshuffler r¨ r r5 rÑ )rÖ Úlsr Úfun_namerË rI r2 s r| r zprocess_namespace.iter« sv è ø ô "XÜrÔØ$&ò "Ñ HdDÙØ× Ñ Ô"Ü$** hÓ/CÜ×#Ñ# CÐ7¨$Ò7°$Ñ7CØ/Ó !ñ "ùs A4A6c óf | j j | j j d¬« y)z&Clear the cache of a Process instance.T)Ú _ignore_nspN)r Ú_initrG rÕ s r| r z process_namespace.clear_cache¸ s! à
|
|
×Ñ °TÐÕ:r~ c ó |D ]> \ }}}d|z }t ||« r|j j d|d}t |« y)z}Given a TestCase instance and a list of tuples checks that
|
the class defines the required test method names.
|
Útest_z class should define a z methodN)rj r rØ ÚAttributeError)r# Ú
|
test_classr r rk Ú meth_namerç s r| Útest_class_coveragez%process_namespace.test_class_coverage¼ sb ð
|
!ò *NHaØ (Ñ*IÜ: yÕ1à!×+Ñ+×4Ñ4Ð7ð 8Ø!} Gð-ð ô % SÓ)Ð)ñ *r~ c ó | j D ch c] }|d }}| j D ch c] }|d }}t t j « D ch c] }|d dk7 s | }}||z |z }|rt d|« y c c}w c c}w c c}w )Nr rk z uncovered Process class names: )r Úignoredr> r¯ r° r± )r# r Úthisr ÚklassÚleftouts r| Útestzprocess_namespace.testÊ s à !ggÖ&!Ð&Ð&Ø!$§¡Ö-A1Q4Ð-Ð-Ü ¤§¡Ó /Ö?q°1°Q±4¸3³;Ð?Ð?Ø'> UÑ*Ù Ü Ð >¸w¸kÐ JÓKÐ Kð ùò 'ùÚ-ùÚ?s B« BÁ B Á"B N)T)$rØ rÙ rÚ r Úutilsr Úgettersr r' r( r+ r¯ Ú RLIMIT_NOFILEr$ r* r& r r) ÚsettersÚNORMAL_PRIORITY_CLASSr ÚIOPRIO_CLASS_NONEÚ IOPRIO_NORMALrm r ÚSIGTERMÚkillersÚ CTRL_C_EVENTÚCTRL_BREAK_EVENTr r r r r^ r r rÀ r~ r| rC rC K sä ñð R Ð $Ð'7¸¸RÐ&@Ð AEð
|
BÐØ R+ tÐ,Ð-Ø BÐ Ø r2Ð Ø BÐØ 2rÐØ BÐØ BØ rÐð
|
Gð
|
BÐØ b"Ð Ø BÐ Ø BØ BØ R Ð$Ø BÐ Ø RÐØ B ¨ Ð0Ø RÐØ R Ð$Ø BÐ Ø r2Ð Ø RÐØ 2rÐØ BÐØ RÐ ð#Gñ& ØVR Ð$Ð%Ñ%ØVR Ð$Ð%Ñ%ØZ RÐ(Ð)Ñ)ØY BÐ'Ð(Ñ(ÙØ] B¨Ð+Ð,Ñ,ÙØXr 2Ð&Ð'Ñ'ÙØX × 4Ñ 4Ð 6¸Ð;Ð<Ñ<ÙØ^ R¨Ð,Ð-Ñ-ÙØY BÐ'Ð(Ñ(ÙØY BÐ'Ð(Ñ(ÙØ] B¨Ð+Ð,Ñ,ÙØ] B¨°EÐ(:Ð;Ð<Ñ<àGÙ ØVT 2Ð&Ð'Ñ'àVf× :Ñ :Ð <¸bÐAÐBÑBÙØX × 4Ñ 4°lÐ CÀRÐHÐIÑIÙÙ Ø F×$<Ñ$<¸aÐ#@À"ÐEÐFÑ FGà F×$8Ñ$8Ð#:¸BÐ?Ð@Ñ @GÙØ^Ñ'8Ó':Ð&;Ð%=¸rÐBÐCÑCð
|
Ð)¨2Ð.Ø BÐØ 2rÐØ b"Ð Ø RÐð Gñ Ø] V×%8Ñ%8Ð$:¸BÐ?Ð@Ñ@Ø] V×%<Ñ%<Ð$>ÀÐCÐDÑDà
|
'/GÑ
|
# gÑ
|
-Còó "ò;ð ñ *ó ð *ð ñLó ñLr~ rC c ó e Zd ZdZddi fddddifddddifddi fd dd
|
difd dd
|
difd dd difd dddifd ej
|
« fi fddddifddi fddi fddddifd ej « fi fddi fddi fddi fddi fgZere re
|
rn eddd
|
difgz Ze r ed di fgz Ze r ed di fgz Ze r ed di fgz Zer ed di fgz Zered di fgz Zed!d"i fgz Zd#di fd$ ej" « gfi fd%di fd&di fgZeZed' « Zej. Zy())rD 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()
|
Ú boot_timerÀ Ú cpu_countÚlogicalFTÚ cpu_statsrt ÚpercpuÚdisk_io_countersÚperdiskÚdisk_partitionsr Ú
|
disk_usagerw rx Ú net_if_addrsÚ net_if_statsr Úpernicr rÂ Ú swap_memoryÚusersÚvirtual_memoryr r r r r Úwin_service_iterÚwin_service_get)Úalgr r¡ ro Úcpu_times_percentc # óÀ K t | « } t j | « | D ]5 \ }}}t t |« }t j |g|¢i |¤}||f 7 ywr
)r rk r r¨ r¯ r5 rÑ )r r rË rI r2 s r| r zsystem_namespace.iter sc è ø ô
|
"XÜrÔØ$&ò "Ñ HdDÜ& (Ó+CÜ×#Ñ# CÐ7¨$Ò7°$Ñ7CØ/Ó !ñ "ùs A A N)rØ rÙ rÚ r r¦ rC Úgetpidr r% r r4 ÚHAS_GETLOADAVGr/ r. r, r r¯ r° r r r r rC r rÀ r~ r| rD rD Ô s ñð
|
b"Ð Ø b9 eÐ,Ð-Ø b9 dÐ+Ð,Ø b"Ð Ø b8 UÐ+Ð,Ø b8 TÐ*Ð+Ø R )¨TÐ!2Ð3Ø B ¨ Ð.Ø ~ rÐ*Ø B ¨ Ð0Ø RÐ Ø RÐ Ø B ¨4Ð 0Ð1Ø ~ rÐ*Ø RÐØ BÐ Ø "bÐØ 2rÐ"ð%Gñ( Ù WØ à R¨(°DÐ)9Ð:Ð;Ñ ;GÙØ\ 2 rÐ*Ð+Ñ+Ù ØÐ+¨R°Ð4Ð5Ñ5ÙØ^ R¨Ð,Ð-Ñ-ÙØÐ&¨¨BÐ/Ð0Ñ0ÙØÐ'¨¨RÐ0Ð1Ñ1ØÐ&¨°"Ð5Ð6Ñ6ð
|
RÐ Ø Ó)Ð*Ð,¨bÐ1Ø BÐ Ø b "Ð%ð Gð Càñ "ó ð "ð ,×?Ñ?Ñr~ rD c ób d }t t t j j fd| |¬« S )zZDecorator which runs a test function and retries N times before
|
actually failing.
|
c ó@ t | dt j ¬« y )Nz
|
, retrying)r6 )rM rx r )rã s r| r¸ z retry_on_failure.<locals>.logfun s Ü zÐ"¬¯©Ö4r~ N)rµ ru r¶ r¸ )r³ rß r rø r1 )r¶ r¸ s r| r@ r@ s1 ò
|
5ô Ü!¤6§;¡;×#8Ñ#8Ð9ØØØô ð r~ c ó fd}|S )z,Decorator to Ignore AccessDenied exceptions.c óF t j « fd« }|S )Nc ó| | i |¤S # t j $ r s t j d« cY S w xY w)Nzraises AccessDenied)r¯ r r rö )rË r# r2 Úonly_ifs r| r3 z9skip_on_access_denied.<locals>.decorator.<locals>.wrapper. sI ø ð :ÙDÐ+ FÑ+Ð+øÜ×&Ñ&ò :ØÐ&Ù"Ø Ü {{Ð#8Ó9Ò9ð :ús -;º;r4 ©r2 r3 rÀ s ` r| rÀ z(skip_on_access_denied.<locals>.decorator- s% ù Ü Ó ô :ó
|
ð :ð r~ rÀ ©rÀ rÀ s ` r| r> r> * s ø ô ð Ðr~ c ó fd}|S )z3Decorator to Ignore NotImplementedError exceptions.c óF t j « fd« }|S )Nc ó | i |¤S # t $ r, s j d}t j |« cY S w xY w)Nz2 was skipped because it raised NotImplementedError)r¤ rØ r rö )rË r# rç r2 rÀ s r| r3 z;skip_on_not_implemented.<locals>.decorator.<locals>.wrapperA s] ø ð
|
(ÙDÐ+ FÑ+Ð+øÜ&ò (ØÐ&Ù"Ø à||Ð&ð '+ð +ð ô {{ 3Ó'Ò'ð (ús 2A ¿A r4 rÁ s ` r| rÀ z*skip_on_not_implemented.<locals>.decorator@ s% ù Ü Ó ô (ó
|
ð (ð r~ rÀ r s ` r| r? r? = s ø ôð" Ðr~ c ó¢ t j « 5 }|j | df« |j « d cddd« S # 1 sw Y yxY w)z6Return an unused TCP port. Subject to race conditions.r rº N)ÚsocketÚbindÚ getsockname)Úhostrh s r| rS rS Z sC ä ð %DØ 4)Ô Ø× Ñ Ó! !Ñ$÷%÷ %ò %ús &AÁAc ó || t t hv rd}t j | |« } t j dvr/|j t j t j d« |j |« |t j k( r|j d« |S # t $ r |j « w xY w)zBinds a generic socket.©r r > ÚntÚcygwinrº r ) r r rÇ r¦ r Ú
|
setsockoptÚ
|
SOL_SOCKETÚ SO_REUSEADDRrÈ r Úlistenr1 re )ÚfamilyÚtypeÚaddrrh s r| rT rT a s à |¤7¬HÐ"5Ñ5ØÜ == Ó &Dð Ü 77Ð*Ñ *Ø OOF× -Ñ -¬v×/BÑ/BÀAÔ FØ $Ø 6×%Ñ%Ò %Ø KKNØ øÜ ò Ø
|
|
Ø ðús ªA7B" Â"B=c óf t j sJ t j j | « rJ | « t j
|
t
|
j |« } |j | « |t
|
j k( r|j d« |S # t $ r |j « w xY w)zBind a UNIX socket.r ) r¯ r r¦ rª r² rÇ r¶ rÈ r rÒ r1 re )r rÔ rh s r| rU rU r s ä <<Ð<Üww~~dÔ#Ð) TÓ)Ð #Ü == ¨Ó .DðØ $Ø 6×%Ñ%Ò %Ø KKNð Køô ò Ø
|
|
Ø ðús Á 5B ÂB0c óÖ t j | t « 5 }|j |« |j d« |j « }t j | t « } |j |« |j « } |j « \ }}||k( r ||fcddd« S |j « 6# t $ r |j « w xY w# 1 sw Y yxY w)z^Build a pair of TCP sockets connected to each other.
|
Return a (server, client) tuple.
|
r N) rÇ r rÈ rÒ rÉ Úconnectra re r )rÓ rÕ Úllr¨ ÚcaddrÚas r| rV rV sÈ ô
|
v{Ó +ð ¨rØ
|
Ø
|
! Ø~~Ó Ü MM&¤+Ó .ð Ø IIdOØMMOEØØ ))+4à5=Ø q6÷ñ ð ð øô ò Ø GGIØ ð ú÷ ð ús$ A C Á)=CÂ0CÃC à C à C(c ó t j sJ dx}} t | t j ¬« }|j d« t j t j t j « }|j d« |j | « ||fS # t $ r& ||j « ||j « w xY w)zBuild 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 rU rÇ r Ú setblockingr¶ rØ r1 re )r ÚserverÚclients r| rW rW s² ô
|
<<Ð<ØÐFVð Ü! $¬V×-?Ñ-?Ô@Ø×Ñ1Ô Ü v~~¬v×/AÑ/AÓBØ×Ñ1Ô ØtÔ ð FÐ Ðøô ò Ø Ð Ø LLNØ Ð Ø LLNØ ð ús B B  /C c # ó< K g } dx}} | j t t j t j « t t j t j
|
« f« t « r_| j t t j t j « t t j t j
|
« f« t r^t rXt « }t « }t |« \ }}t |t j
|
¬« }|||fD ] }| j |« | | D ] }|j « ||fD ] }|t |« y# | D ] }|j « ||fD ] }|t |« w xY ww)z1Open as many socket families / types as possible.NrÝ )ÚextendrT rÇ r r Ú
|
SOCK_DGRAMr r r r0 rK rW rU rL re rH )ÚsocksÚfname1Úfname2Ús1Ús2Ús3rT rÆ s r| rX rX ¯ sg è ø ð EØÐFVð#Ø Ü ¬×(:Ñ(:Ó ;Ü ¬×(9Ñ(9Ó :ð
|
ô ô ?Ø LLÜFOO¬V×-?Ñ-?Ó@ÜFOO¬V×->Ñ->Ó?ðô õ Õ-Ü \FÜ \FÜ$ VÓ,FBÜ! &¬v×/@Ñ/@ÔABØ"b\ò Ø Qð à àò AØ GGIð à fÐ%ò #EØÑ ÜEÕ"ñ #øð ò AØ GGIð à fÐ%ò #EØÑ ÜEÕ"ñ #üs) F D0E) Ä: F ÅF Å)!FÆ FÆF c óX t |t j « sJ |« |t j k( rs| j d« D cg c] }t |« }}t |« dk( sJ | « |D ] }d|cxk r dk rJ | « J | « t j | « y|t j k( r-t | t « sJ | « t j | « y|t j k( r t j d| « J | « yt# d|« c c}w )z[Check a net address validity. Supported families are IPv4,
|
IPv6 and MAC addresses.
|
rg r r éÿ z([a-fA-F0-9]{2}[:|\-]?){6}Nzunknown family )rx ÚenumÚIntEnumrÇ r ru rt r§ Ú ipaddressÚ IPv4Addressr râ Ú IPv6Addressr¯ ÚAF_LINKrà rä r± )rÕ rÓ r ÚoctsÚnums r| rQ rQ Î s ô fdllÔ +Ð3¨VÓ3Ð +Ø Ò Ø $§
|
¡
|
¨3£Ö01AÐ0Ð0Ü4yA~Ð#tÓ#~Øò )CØ?s?Ð ( DÓ (?Ð ( DÓ (?ð )ä× Ñ dÕ#Ø 6??Ò "Ü$¤Ô$Ð* dÓ*Ð$Ü× Ñ dÕ#Ø 6>>Ò !ÜxxÐ5°tÓ<ÐHÐNÈ$ÓNÑHä?¨6¨*Ð5Ó6Ð6ùò 1s ÁD'c ór d }d }d }d }d } || « || « || « || « || « y)z*Check validity of a connection namedtuple.c óJ t | « dk( }t | « dv sJ t | « « | d | j k( sJ | j « | d | j k( sJ | j « | d | j k( sJ | j « | d | j k( sJ | j « | d | j
|
k( sJ | j
|
« | d | j k( sJ | j « |r$| d | j k( sJ | j « y y )
|
Nr¤ > r r¤ r rº rh r r r r )r§ r: rÓ rÔ ÚladdrÚraddrr\ rG )rj Úhas_pids r| Ú check_ntuplez-check_connection_ntuple.<locals>.check_ntupleå s Üd)q.Ü4yFÑ"Ð-¤C¨£IÓ-Ð"ØAw$''Ò!Ð* 4§7¡7Ó*Ð!ØAw$++Ò%Ð2 t§{¡{Ó2Ð%ØAw$))Ò#Ð. T§Y¡YÓ.Ð#ØAw$**Ò$Ð0 d§j¡jÓ0Ð$ØAw$**Ò$Ð0 d§j¡jÓ0Ð$ØAw$++Ò%Ð2 t§{¡{Ó2Ð%Ù Ø7dhhÒ&Ð 0¨¯©Ó 0Ñ&ð r~ c ó | j t t t hv sJ | j « t | j t
|
j « sJ | « | j t k( rUt j | j | j « 5 } |j | j d df« d d d « y | j t k( r/| j t j k( sJ | j « y y # t $ r(}|j t j k7 r Y d }~xd }~ww xY w# 1 sw Y y xY wrû )rÓ r r r¶ rx rì rí rÇ rÔ rÈ rö r ÚerrnoÚ EADDRNOTAVAILr\ r¯ Ú CONN_NONE)rj rT ræ s r| Ú check_familyz-check_connection_ntuple.<locals>.check_familyñ sÿ Ø{{w¬´'Ð :Ñ:ÐG¸D¿K¹KÓGÐ:Ü$++¤t§|¡|Ô4Ð:°dÓ:Ð4Ø ;;'Ò !ô
|
t{{¨D¯I©IÓ6ð ¸!ð ØFFDJJ qM¨1Ð-Ô.÷ ð ð [[GÒ #Ø;;¤&×"2Ñ"2Ò2Ð ?°D·K±KÓ ?Ñ2ð $øô ò Øyy¤E×$7Ñ$7Ò7Ø ô 8ûð ú÷ ð ús0 ÂD9Â DÄ D6Ä D1Ä,D9Ä1D6Ä6D9Ä9Ec ó t t dt « « }| j t j t j
|
|hv sJ | j « t | j t j « sJ | « | j t j
|
k( r/| j t j k( sJ | j « y y )NÚSOCK_SEQPACKET) r¨ rÇ ÚobjectrÔ r rã rx rì rí r\ r¯ rý )rj r s r| Ú
|
check_typez+check_connection_ntuple.<locals>.check_type s¨ ä ¤Ð)9¼6»8ÓDØyyÜ × Ñ Ü × Ñ Ø ð
|
ñ
|
ð ð 99ó ð
|
ô
|
$))¤T§\¡\Ô2Ð8°DÓ8Ð2Ø 99×)Ñ)Ò )Ø;;¤&×"2Ñ"2Ò2Ð ?°D·K±KÓ ?Ñ2ð *r~ c ó | j | j fD ]î }| j t t hv r t |t « sJ t |« « |s>t |j t « sJ t |j « « d|j cxk rdk sn J |j « t |j | j « »| j t k( sÏt |t « ràJ t |« « y )Nr iÿÿ )rö r÷ rÓ r r rx rr rÔ Úportrt rQ Úipr¶ râ )rj rÕ s r| Ú check_addrsz,check_connection_ntuple.<locals>.check_addrs sÆ àZZ §¡Ð,ò 9DØ{{w¬Ð 1Ñ1Ü! $¬Ô.Ð:´°T³
|
Ó:Ð.ÙØ Ü! $§)¡)¬SÔ1ÐB´4¸¿ ¹ ³?ÓBÐ1ØDIIÔ.¨Ô.Ð9°· ± Ó9Ð.Ü! $§'¡'¨4¯;©;Õ7ؤÓ'Ü! $¬Õ,Ð8¬d°4«jÓ8Ð,ñ 9r~ c ó* t | j t « sJ | j « t t « D cg c]$ }|j d« st t |« & }}| j |v sJ | j « | j t t hv rB| j t k( r/| j t j k7 sJ | j « y | j t j k( sJ | j « y c c}w )NÚCONN_) rx r\ râ r> r¯ rë r¨ rÓ r r rÔ r rý )rj r Úvalidss r| Ú check_statusz-check_connection_ntuple.<locals>.check_status sÏ Ü$++¤sÔ+Ð8¨T¯[©[Ó8Ð+ä(+¬F« ö
|
Ø#$°q·|±|ÀGÕ7LGFAÕ ð
|
ð
|
ð {{fÑ$Ð1 d§k¡kÓ1Ð$Ø ;;7¤HÐ-Ñ -°$·)±)¼{Ò2JØ;;¤&×"2Ñ"2Ò2Ð ?°D·K±KÓ ?Ñ2à;;¤&×"2Ñ"2Ò2Ð ?°D·K±KÓ ?Ñ2ùò
|
s ½DÁDNrÀ )rj rù rþ r r r
|
s r| Úcheck_connection_ntupler â sH ò
|
1ò@ò"
|
@ò 9ò @ñ ÔÙÔÙtÔÙÔÙÕr~ c óÆ g }| D ]Y }t r@|j t j k( r#t r d|j
|
v rt d| « I|j |« [ |S )ztOur process may start with some open UNIX sockets which are not
|
initialized by us, invalidating unit tests.
|
z/syslogz skipping )r rÓ rÇ r¶ r r÷ r rL )ÚconsÚnewrj s r| rR rR - s] ð CØò Ý T[[¤F§N¡NÒ2Ý d§j¡jÑ0Ü $ Ð(Ô)ØØ
|
|
4Õð ð Jr~ c ó, t j | « S rÓ )Ú importlibÚreload)Úmodules r| rY rY @ s Ü × Ñ FÓ #Ð#r~ c ó8 t j j t j j | « « d }t j
|
j || « }t j
|
j |« }|j j |« |S rû )
|
r¦ rª ÚsplitextrQ r ÚutilÚspec_from_file_locationÚmodule_from_specÚloaderÚ exec_module)rª r ÚspecÚmods r| rZ rZ D sk Ü 77× Ñ BGG× ,Ñ ,¨TÓ 2Ó 3°AÑ 6DÜ >>× 1Ñ 1°$¸Ó =DÜ
|
..×
|
)Ñ
|
)¨$Ó
|
/CØKK×ÑCÔ Ø Jr~ c ó< t j | t d¬« y)zRaise a warning msg.rh r» Nr½ )rç s r| r[ r[ Q s ä MM#{¨qÖ1r~ c óÄ t | « }|j }t |« dk7 s |d t uryt |dd« }t |t « syt d |D « « S )z-Check if object is an instance of namedtuple.rº r FÚ_fieldsNc 3 ó< K | ] }t |t « y wrÓ )rx râ )Ú.0Úns r| ú <genexpr>z is_namedtuple.<locals>.<genexpr>_ s è ø Ò- az!S×!Ñ-ùs )rÔ Ú __bases__r§ rr r¨ rx r )r ÚtÚbrr s r| r] r] V sY ä QAØ AÜ
|
1v{ad¤%Ñ'ØÜ9dÓ#AÜ aÔ ØÜ Ñ-¨1Ô-Ó -Ð-r~ c # ó K t rdnd}d}t | |z ¬« }t j « j « D cg c]Y }t
|
j j |j « d |k( r(||j j « v r |j [ }}t j |« }t j ||« t j |« | t |« yc c}w # t |« w xY ww)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.
|
ÚpypyÚpythonz.sorâ rº N)r rK r¯ r° r r¦ rª r Úlowerrk rl r¬ rÝ ÚctypesÚCDLLrH )rã r¡ ÚextÚdstr Úlibsrg s r| r\ r\ d sÔ è ø õ f (ØÜ ¨¡ Ô-ô ^^Ó%×1Ñ1Ó3ö
|
àÜww× Ñ §¡Ó'¨Ñ*¨cÒ1°c¸Q¿V¹V¿\¹\»^Ñ6Kð FFð
|
ð
|
ô
|
mmDÓ!ÜSÔ!ð Ü KKÔ ØIä Õ ùò
|
øô Õ üs+ A DÁA C3 -DÃC8 Ã'DÃ8 DÄDc # óØ K ddl m} ddl m} d}t | |z ¬« }t j
|
« j « D cg c] }|j j « j |« radt j j |j « j « v r(d|j j « vr |j }}t rt|srt j
|
« j « D cg c]G }dt j j |j « j « v r |j I }}t j |« }t j ||« d } t j" |« }| |Tt j$ j& j( } |j* g| _ | |j. « }
|
|
|
dk( r |« t1 |« y c c}w c c}w # |Tt j$ j& j( } |j* g| _ | |j. « }
|
|
|
dk( r |« t1 |« w xY ww)
|
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 )ÚWinError)Úwintypesz.dllrâ r( Úwow64r' N)r* r0 r1 rK r¯ r° r rª r) r} r¦ rQ r rk rl r¬ rÝ ÚWinDLLÚwindllÚkernel32Ú FreeLibraryÚHMODULEÚargtypesÚ_handlerH ) rã r0 r1 r, r- r r. rg Úcfiler6 rÉ s r| r\ r\ | sì è ø õ $Ý#àÜ ¨¡ Ô-ô ^^Ó%×1Ñ1Ó3ö
|
àØvv||~×&Ñ& sÔ+ØBGG× ,Ñ ,¨Q¯V©VÓ 4× :Ñ :Ó <Ñ<Øqvv||~Ñ-ð FFð
|
ð
|
õ ô Ó)×5Ñ5Ó7öàØRWW× -Ñ -¨a¯f©fÓ 5× ;Ñ ;Ó =Ñ=ð ðDð ô
|
mmDÓ!ÜSÔ!Øð ÜMM #Ó&EØIð Ð Ü $mm× 4Ñ 4× @Ñ @ Ø(0×(8Ñ(8Ð'9 Ô$Ù! %§-¡-Ó0Ø!8Ù"*Ð$Ü Õ ùò?
|
ùòøð" Ð Ü $mm× 4Ñ 4× @Ñ @ Ø(0×(8Ñ(8Ð'9 Ô$Ù! %§-¡-Ó0Ø!8Ù"*Ð$Ü Õ üs: AI*ÁBG:Ã.I*ÄA G?Å/I*Å?H ÆA,I*ÈA#I'É'I*c ó t d¬« y )NTr )r8 rÀ r~ r| Úcleanup_test_procsr< ° s
|
äDÖ!r~ c ó, t j | « S rÓ )rx Úexit)r rk s r| r_ r_ º s ´·±¸#³ r~ rÓ )F)TFr )z 127.0.0.1)rÌ r
|
)¿r r ré r* rì rû r5 rD r rî r¦ rp rk rà rb ry r¬ r rÇ rÎ rv rx rç rO r r* Ú tracebackr= r¾ r r r r Ú ImportErrorr¯ r r r r r
|
r r r Úpsutil._commonr r r r r Úpsutil._psposixr Ú__all__Úbuiltin_module_namesr r r_ r r3 r5 Úmaxsizer# Úmachiner) r4 ÚRISCV64r} r1 r2 r r r" r r r¹ r r Údecoder ÚgetfilesystemencodingÚASCII_FSrª r« r- rÚ Ú__file__r Úgetr rÈ rj r° r$ r& rº r( r) r0 ÚHAS_NET_IO_COUNTERSr* r' r+ r, r. r/ Ú HAS_THREADSÚgetuidÚ SKIP_SYSCONSr\ r r- r1 rà rÑ rM Ú
|
format_excr r% r´ r r ro Údevnullr re r> rë r¨ r! r r¶ r) rE rR rF rß rø ÚmodulesrÁ r& r< r7 r9 r; r: r6 r r r7 r8 rM rL r³ r rO rÌ rP rN rH rØ rê rG rI rJ rK rí rB r rþ rA rE rm rC rD r@ r> r? rS rT rU rV rW rX rQ r rR rY rZ r[ r] r\ r< )r s 0r| ú<module>rT s ðñ
|
ã Û Û Û Û Û Û Û Û Û Û Û Û Û Û Û Û Û Û Û Û
|
Û Û Û Û Û Û Û Ý Ý Ý ðÛó Ý Ý Ý Ý Ý Ý Ý Ý Ý &Ý Ý "Ý &Ý (áÝ(ò# ðZ S×-Ñ-Ð-à! R§Z¡ZÐ/ÒO°>ÀRÇZÁZÐ3OØ
|
Ø RZZÐ 'Ø'¨2¯:©:Ð5à ;;Ñ à
|
(×
|
Ñ
|
Ó
|
×
|
"Ñ
|
"Ó
|
$Ð(<Ð
|
<Ø
|
(×
|
Ñ
|
Ó
|
Ñ
|
)ð ñó ðñ( Ù ? XÑ-LÙ ? gÑ-LàLØLð
|
à#Ð Ø'Ð àá Ø!OJØaÑNØÑÐØAÑ Ðð
|
77fÒà yryy{m¨1Ð-Mà yryy{m¨1Ð-MØà%×,Ñ,¨VÐ5FÓGÐ Ø $3× $Ñ $Ó &× ,Ñ ,Ó .Ð2GÐ Gð 77× Ñ ØGGLL Ó*¨D°$Ó7ó ð jjnnØ"'',, x°Ó;ó ð
|
ww×ѨÓ1Ó2ñ 6>>¨>Ó:Ð Ùfnn iÓ0 Ù Ó.Ù V^^ XÓ .
|
Ù&..¨-Ó8Ø Ò.¨ YÐ Ù fÐ&7Ó8Ð Ù6>>¨9Ó5Ð Ù v~~¨}Ó=Ð Ù V^^ XÓ .
|
Ù fÐ&7Ó8Ð Ù6 >Ó2Ð Ù" 6Ð+AÓBÐ Ùfnn iÓ0 Ø Ò2 ) "§)¡)£+°Ñ"2 ðØ%ÒH©$Ð/E¨v×/EÑ/EÓ/GÓ*HKðÙ6 :Ó.ÒJ±4¸¸¿¹Ó8IÓ3JLò)ñX )]Ñ
|
NÙ
|
rzz4Ó
|
Ø Ô ñ !$ F£ öØ ¨q¯|©|¸IÕ/FGFAÕòÐ ñ &)¡V£XÓ
|
.áÐ Ù ÷U#ñ U#ðr , × Ò Ô ð
|
>Ø Fà 'CKKÑØ× Ò Ô ô(×!Ò!ô (ò` ð ò&ó ð&ðR ñ# ó ð# òL& ðR ñó ðð& ñó ðð0 &~~¸Nó Q/óh -òJ!ò0 ÷6ñ 6ñr Ø×"Ò"Ø Ø Ø ô ñ ó ð ñ Ø .Ð1Ø Ø Ø ô ò ó ð ñ Ø v{{× 4Ñ 4Ð5Ø Ø Ø ô ñ ó ð ò òD ð ×Òñó ðòóó4 ô&VBX×&Ò&ô VBðN ×ÒDÐ!5ÐÓ6ôg%^ó g%ó 7ðg%òTò$ ÷FLñ FL÷RC@ñ C@ðL (ó ó ó&ó:%ð [°tó ð" !'× 2Ñ 2ó ó ò. ð. ×Òñ#ó ð#ò<7ò(HòV ò&$òò2ò
|
.ñ à× Ò ò ó ñ ð. × Ò ò* ó ð* ðf ñ"ó ð"ñ ØFMM&..Ñ">Õ?ð øða< ò Ø FðûðR ò ØFOOÐ%I×%Ñ% eÐ-A¨Y×-AÑ-AÓ-CÓDÔEØKðûð
|
ò ØFOOÐ%I×%Ñ% eÐ-A¨Y×-AÑ-AÓ-CÓDÔEØLðüòpsB Â[ Ï[ Ï$"\ Ñ ]Ñ# ]Û[Û [Û9\Ü \Ü9]Ý ]
|
