python (3.11.7)
Browse
Usage
Versions
eU' R d dl Z d dlZ d dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dlm Z d dlm Z d dlm Z d dlm Z d dlm!Z! d dlm"Z" d d lm#Z# e j$ d
Z% e j& d dl'Z'd dl(Z)d dl*Z)d dl+Z)d dl,Z)d dl-Z)d dl.Z)d d l)m/Z/ d d l)m0Z0 e0j1 Z2n
# e3$ r d
Z2Y nw xY w d dl4m5Z5m6Z6 dZ7n
# e3$ r d
Z7Y nw xY w d dl)m8Z8 dZ9n
# e3$ r d
Z9Y nw xY w d dl:Z:n
# e3$ r dZ:Y nw xY we j; r e j< d dZ=d Z>d Z?d Z@e jA dk r d dl)mBZB d ZCe/jD ZEdZFd
ZGeGrd\ ZHZIZJnd\ ZHZIZJe jK ZL eMe%dd
ZNejO d k ZPd d l(mQZQ d ZR e jS d ZTn # d ZTY nxY wd!d"gZU d d#lVmWZWmXZXmYZYmZZZ n# e3$ r e[ZWdxZXxZYZZY nw xY wd$ Z\d% Z] G d& d'e j^ Z_ G d( d)e[ Z` G d* d+e[ Zad, Zb G d- d. Zc G d/ d0ea Zd G d1 d2e)je Zf G d3 d4ea Zgd5 Zhd6 Zi G d7 d8ea Zj G d9 d:ea Zk G d; d<ea Zl G d= d>ea Zm G d? d@ea Zn G dA dBe[ ZodC Zp G dD dEe[ Zq G dF dGe[ Zr G dH dIea Zs G dJ dKea Zt G dL dMea Zu G dN dOea ZvddQZwdR ZxdS ZydT Zz G dU dVe[ Z{ G dW dXe| Z}dY Z~ G dZ d[ea Zd\ Zd] Z G d^ d_ea Z G d` daea Zd dbl,mZmZmZ G dc dde[ Zde Z G df dge Z G dh die Ze djek e dledmn e doeep G dq drea Z ej Zds Z G dt due Ze dvek G dw dxe Ze dv dyZ G dz d{ea Z e j d| G d} d~ea Z e>d Z G d dea Z G d dea Z G d dea Z G d dea Z e j e2d e j d| G d dea Z G d dea Z G d deW Z G d dea Z e j e9d e j d| G d dea Z G d dea Z G d de j^ Z G d dea Z G d dea Z G d de j^ Z e j d| G d de j^ Zd Z e j d| G d de j^ Zd Zd Zd Zd Z G d de[ Z G d de j^ Z G d de j^ Z G d de j^ Z G d de j^ Z G d de j^ Z G d de j^ Z G d de j^ Z G d de j^ Z G d de j^ Z G d de j^ Z e j ejO d k d G d de j^ Z G d de j^ Z G d de j^ Z e j d| G dĄ de j^ Z G dƄ de j^ Z G dȄ de j^ Z G dʄ de[ Z G d̄ de Z G d΄ de Z G dЄ de Z dd҄Z e j ee%dӦ dԦ e j ejO dk d֦ G dׄ de j^ ZdS ) N)support)hashlib_helper)
import_helper) os_helper)
script_helper)
socket_helper)threading_helper)warnings_helper_multiprocessing)util) reductionF)ValuecopyT)
shared_memoryz?libasan has a pthread_create() dead lock related to thread+fork皙?c , | d S )Nlatin)encode)ss N/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/_test_multiprocessing.pyr r [ s 88G c t | t j j r*| | d S d S N)
isinstancemultiprocessingqueuesQueueclose join_thread)queues r close_queuer! _ sI % /566
r c . t j | d S r )r r )processs r join_processr$ e s )))))r posix)resource_trackerc : t j | | d S r )r& _CLEANUP_FUNCS)namertypes r _resource_unlinkr+ n s '.t44444r )g=
ףp=?gffffff?gffffff?)r r r HAVE_BROKEN_SEM_GETVALUEwin32waitc 8 ||dk rd }t | g| S )N r. )handletimeouts r wait_for_handler4 s' w}} ' " ""r SC_OPEN_MAX __main__z$test.test_multiprocessing_forkserver) Structurec_intc_double
c_longlongc d} t j d }n# t t f$ r Y dS w xY w|dk s|| k rdS t j d| z )zACheck that the system supports enough semaphores to run the test.r6 SC_SEM_NSEMS_MAXNzHThe OS doesn't support enough semaphores to run the test (required: %d).)ossysconfAttributeError
ValueErrorunittestSkipTest) nsems_minnsemss r check_enough_semaphoresrG s I
-.. J '
{{ey((
>@I J K K Ks ..c fd}|S )a Returns a decorator: raises SkipTest when SM != spawn at test time.
This can be useful to save overall Python test suite execution time.
"spawn" is the universal mode available on all platforms so this limits the
decorated test to only execute within test_multiprocessing_spawn.
This would not be necessary if we refactored our test suite to split things
into other test files when they are not start method specific to be rerun
under all start methods.
c J t j fd }|S )Nc z t j x}dk rt j d|d | i |S )Nspawn
start_method=z, not 'spawn'; )r get_start_methodrC rD )argskwargs start_methodreason test_items r spawn_check_wrapperzKonly_run_in_spawn_testsuite.<locals>.decorator.<locals>.spawn_check_wrapper sS / @ B BB wNN '(Q<(Q(Q(Q(QRRR 9d-f-- -r ) functoolswraps)rR rS rQ s ` r decoratorz.only_run_in_spawn_testsuite.<locals>.decorator s? # # . . . . .
$ # .
#"r )rQ rV s ` r only_run_in_spawn_testsuiterX s$ # # # # # r c X e Zd ZdZ ej ej dk d d ZdS )TestInternalDecoratorszBLogic within a test suite that could errantly skip tests? Test it!r- z test requires that fork exists.c 2 t j dk rt j d t d d }n/# t
$ r"}| d| Y d }~nd }~ww xY wt j d } t j dd | | d t j d
d | t j 5 } | d d d n # 1 swxY w Y |
dt |j |
d t |j t j |d d S # t j |d w xY w) NrK z'only run in test_multiprocessing_spawn.ztesting this decoratorc dS N rW rW r r return_four_if_spawnzUTestInternalDecorators.test_only_run_in_spawn_testsuite.<locals>.return_four_if_spawn s qr z.expected decorated `def` not to raise; caught T
allow_noneforcer^ forkrL )
r rM rC rD rX Exceptionfailset_start_method assertEqual assertRaisesassertInstr exception)selfr_ errorig_start_methodctxs r test_only_run_in_spawn_testsuitez7TestInternalDecorators.test_only_run_in_spawn_testsuite s + - - 8 8#$MNN N N
()A
B
B
C
B
N N N IILsLL M M M M M M M M N , < M M M L ,WD A A A A 1 1 3 3Q 7 7 7 ,V4 @ @ @ @""8#455
'$$&&&
'
'
'
'
'
'
'
'
'
'
'
'
'
'
' MM2C
4F4F G G G MM/3s}+=+= > > > ,->d K K K K K KO ,->d K K K K KsI A
A2A--A2 A)E> 4 D ? E> DE> DAE> >FN) __name__
__module__ __qualname____doc__rC skipIfsysplatformrq rW r r rZ rZ sP LLX_S\W,.OPPL L QPL L Lr rZ c e Zd Zd Zd ZdS )
TimingWrapperc " || _ d | _ d S r )funcelapsed)rm r| s r __init__zTimingWrapper.__init__ s r c t j } | j |i |t j |z
| _ S # t j |z
| _ w xY wr )time monotonicr| r} )rm rN kwdsts r __call__zTimingWrapper.__call__ s^ N 0 49d+d++ >++a/DLL4>++a/DL / / / /s = ANrr rs rt r~ r rW r r rz rz s2 0 0 0 0 0r rz c ( e Zd ZdZd Zd Zd ZeZdS ) BaseTestCase) processesmanagerthreadsc F t r| ||d d S d S N )
CHECK_TIMINGSassertAlmostEqualrm abs r assertTimingAlmostEqualz$BaseTestCase.assertTimingAlmostEqual s2 , " "1a + + + + + , ,r c \ || }| || S # t $ r Y d S w xY wr )rh NotImplementedError)rm valuer| rN ress r assertReturnsIfImplementedz'BaseTestCase.assertReturnsIfImplemented sN 0$+C ##E3// / # DD s
++c t d )Nz#shouldn't try to pickle a test case)r )rm rN s r
__reduce__zBaseTestCase.__reduce__ s !"GHHHr N)rr rs rt
ALLOWED_TYPESr r r
__reduce_ex__rW r r r r sJ 7M, , ,0 0 0I I I MMMr r c | S # t $ r: | j cY S # t $ r" | j cY cY S # t $ r t w xY ww xY ww xY wr ) get_valuerA _Semaphore__value_valuer rm s r r r s *~~ * * * *) ) ) ) * * *
*{"""""!
*
*
*))
* **s8
A*A
AA AA AAAc e Zd Zd ZdS )
DummyCallablec 0 | d d S N put)rm qcs r r zDummyCallable.__call__* s ar N)rr rs rt r rW r r r r ) s# r r c e Zd ZdZd Zd Z ej d d Ze d Z
d Z e d Z d Z
e d
Zd Ze d Ze d
Zd Z ej ej d d Ze d Ze d Ze d Zd Zd Z d Z d Z d Z e d Z d Z!e d Z"d Z#e d0d Z$d Z% ej d! d" Z&d# Z'e d$ Z(d% Z)e d& Z*d' Z+e i fd( Z,d) Z-d* Z.e d1d, Z/d- Z0d. Z1d/ Z2d S )2 _TestProcessr r c @ | j dk r-| d | j | }|j }| | | |j | |t | t | dk | |j t j | |j d d S )Nr test not appropriate for {}r )TYPEskipTestformatcurrent_processauthkey
assertTrueis_alivedaemonassertIsInstancebyteslenrh identr? getpidexitcode)rm currentr s r test_currentz_TestProcess.test_current3 s 9 ! ! MM7>>tyII J J J&&((/ ((**+++ GN*+++ gu--- G q())) 444 )400000r c | j dk r | d| j t j t j t j t j g}|D ]n}| | | }| |
| |j d od S )Nr ztest not appropriate for r )
r r rw
executabler pathlibPathset_executableProcessstartjoinrh r )rm pathspathps r test_set_executablez _TestProcess.test_set_executableA s 9 ! ! MMAdiAA B B B N N ! ! # # L ( (
, ,D % % % A
GGIII
FFHHH QZ + + + + , ,r cpuc dddgdf}t t f}t j || }|D ]\ }}| || 5 | d }| | j |||f }d|_ | |
}| || | t | d d d n # 1 swxY w Y d S )Nr rk r )rN args_typetargetrN T)listtuple itertoolsproductsubTestr r
_test_argsr r getrh r r! ) rm
args_cases
args_types
test_casesrN r r r
child_argss r test_args_argumentz _TestProcess.test_args_argumentP s; T*
E]
&z:>>
)
OD) 49 ==
JJqMMLLiiD >R>RLSS UUWW
T222A
s B%C::C> C> c 0 | | d S r r )clsr args r r z_TestProcess._test_argse s c
r c | j dk r-| d | j | | j }| |j | j | | j d }| |j | | j d }| |j d S )Nr r r Tr r F)
r r r r _testrh r r r assertFalse)rm proc0proc1proc2s r test_daemon_argumentz!_TestProcess.test_daemon_argumenti s 9 ! ! MM7>>tyII J J J DJ // t';';'='='DEEE DJt << %%% DJu == &&&&&r c R | }| | | | | |j | j dk rC| t |j | |j d S d S )Nr )r r r) r r r pid)r r rN r r s r r z_TestProcess._testu s %%'' d d gl 8y
EE%(( ) ) )
EE'+ ! r c | j dk r-| d | j | | | d \ }}| | j |f }| | |
\ }}| || j
| |t j | || j d S )Nr r Fduplexr )r r r assertIsNoneparent_processPiper _test_send_parent_processr r recvrh r r r? r r) )rm rconnwconnr
parent_pid parent_names r test_parent_process_attributesz+_TestProcess.test_parent_process_attributes s 9 ! ! MM7>>tyII J J J $--//000yyy.. u LL >eXL N N "'**,,
K T%9%9%;%;%?@@@ RY[[111 d&:&:&<&<&ABBBBBr c t ddl m} | | j | j g d S )Nr r )multiprocessing.processr sendr r) r r r s r r z&_TestProcess._test_send_parent_process sG ::::::
NN$$(..*:*:*?@AAAAAr c | j dk r-| d | j | d \ }}| | j |f }| | t j st d | }| |d |
| | t j st d | }| |d d S )
Nr r Fr r r3 z(Could not communicate with child processalive not alive)r r r r r _test_create_grandchild_processr pollr LONG_TIMEOUTAssertionErrorr rh terminater )rm r r r parent_process_statuss r test_parent_processz _TestProcess.test_parent_process s8 9 ! ! MM7>>tyII J J J
yyy.. u LL7ui
I
I zz'"6z77 M !KLL L %
.888
zz'"6z77 M !KLL L %
. <<<<<r c | | j |f }| t j d d S )Nr i, )r _test_report_parent_statusr r sleep)r r r s r r z,_TestProcess._test_create_grandchild_process s: KKs =UIK N N
3r c . ddl m} | | rdnd | t
j | | rdnd d S )Nr r r r r )r r r r r r
SHORT_TIMEOUTr s r r
z'_TestProcess._test_report_parent_status s ::::::
nn . . 7 7 9 9J77{KKK g&; <<<
nn . . 7 7 9 9J77{KKKKKr c | d }| }|ddf}ddd}d}| | j ||| }d|_ | }| j d k r | |j |j | | d
| |j d |
|| | t | t u | |j d | | |j d | | d | || | | |dd | | | | | |j | j d k rZ| | |j | | |j | | |j d | | d
|
|| t- | d S ) Nr gR Q@)hellobye SomeProcess)r rN rO r) Tr Fr )r Eventr r r r r rh r r assertNotInactive_childrenr typer r r rj r r) r r r! )rm r erN rO r) r r s r test_processz_TestProcess.test_process s JJqMM JJLL1ay D)) LL:Dd
&&(( 9 ! ! QY 8 8 8 u--- 4((( D 0 0 2 2333 T 1 1 3 344<=== T*** T*** t,,,
a--//000 $qrr(+++ &))) !&))) 9 ! ! QUUWWgo 6 6 6 QUUWWae , , , Q''' u--- D 0 0 2 2333Ar zneeds native_idc | j dk r-| d | j t j j }| d }| | j |f }| |
}| t | |
|| d S )Nr r r r )r r r threading main_thread native_idr r "_test_process_mainthread_native_idr r r r! assertNotEqual)rm current_mainthread_native_idr r child_mainthread_native_ids r !test_process_mainthread_native_idz._TestProcess.test_process_mainthread_native_id s 9 ! ! MM7>>tyII J J J'0'<'>'>'H$ JJqMM LL GqdL S S %&UUWW" A 8:TUUUUUr c ` t j j }| | d S r )r r r r )r r mainthread_native_ids r r z/_TestProcess._test_process_mainthread_native_id s- ( 4 6 6 @ "#####r c . t j d d S )Nd r r r s r _sleep_somez_TestProcess._sleep_some s
3r c . t j | d S r r' )r delays r _test_sleepz_TestProcess._test_sleep s
5r c | j dk r-| d | j | | j d_ | d | |
| j d t j
}| |d d | |j d | d | |d d | |j d | d t! j d | t% t& d rÈfd
}t' j t& j | } t' j d | | d t' j d t' j t& j | nV# t' j d t' j t& j | w xY w| | d | |j d | d | |
j S )
Nr r r Tr r1 r> r alarmc ( t dz )Nzjoin took too long: %s RuntimeError)rN r s r handlerz+_TestProcess._kill_process.<locals>.handler s "#;a#?@@@r
F)r r r r r) r r rh r rj r r rz r r r} r r hasattrsignalSIGALRMr. r )rm methr r2 old_handlerr s @r
_kill_processz_TestProcess._kill_process s 9 ! ! MM7>>tyII J J J LL 0L 1 1 t,,,
a--//000 T*** QV$$ a$''' $$T\3777 t,,, b4((( $$T\3777 t,,,
1
Q 67 # #
+
A
A
A
A
A -@@K
; R ... Q
fnk:::: Q
fnk:::: TTVVT * * * $$T\3777 u--- D 0 0 2 2333 zs 2I2 25J'c | t j j }| |t
j d S r )r9 r r r rh r5 SIGTERMrm r s r test_terminatez_TestProcess.test_terminate2 s; %%o&=&GHH FN?33333r c | t j j }t j dk r#| |t j d S | |t j d S Nnt)
r9 r r killr? r) rh r5 SIGKILLr; r< s r test_killz_TestProcess.test_kill6 sf %%o&=&BCC
7d?? X 7 7 7 7 7 X 7 7 7 7 7r c t j }n# t $ r d}Y nw xY w| t | t
u | |dk d S r )r cpu_countr r r int)rm cpuss r test_cpu_countz_TestProcess.test_cpu_count= st ",..DD" DDD T
c)*** """""s %%c | t | t | t
j t f }| || d|_ |
| || | | || d S Nr T)
rh r r r r r r DELTAr r r rj r rm r s r test_active_childrenz!_TestProcess.test_active_childrenE s d 2 2 4 455t<<< LL
%L : : D 0 0 2 2333
a--//000 D 0 0 2 233333r c | | t | dk r\t d D ]N}| | j |||gz f }| | Md S d S Nr r )r r ranger _test_recursionr r )r r idir s r rQ z _TestProcess._test_recursionR s
2 r77Q;;1XX
KK .eRV_
;
r c | d \ }}| |g t j t g }| r;| | | ;g dgddgddgdgddgddgg}| || d S )NFr r r ) r rQ r r rK r appendr rh )rm r r resultexpecteds r test_recursionz_TestProcess.test_recursion] s yyy.. u UB'''
5jjll ( MM%**,, ' ' ' jjll (
cAAcAA
*****r c 0 | d d S )Ng $@r. r events r _test_sentinelz_TestProcess._test_sentinelq s
4r c | j dk r-| d | j | }| | j |f }| t 5 |j d d d n # 1 swxY w Y | |
|j |j }| |t | t |d | | | t |d d S )Nr r r r1 r r )r r r r r r\ ri rB sentinelr
addCleanupr r rF r r4 setr )rm r[ r r^ s r
test_sentinelz_TestProcess.test_sentinelu sg 9 ! ! MM7>>tyII J J J
LL 35(L C C
z
*
*
JJ : h,,, 3???@@@
!<<<=====s BB B r Nc Z || t j | d S r )r rw exit)r rcr s r _test_closez_TestProcess._test_close s% =
EEGGG r c b | j dk r-| d | j | }| | j d|i }d|_ | | | d |
t 5 | d d d n # 1 swxY w Y |
d | | | d | |j d | |
t 5 | d d d n # 1 swxY w Y |
t 5 | d d d n # 1 swxY w Y |
t 5 | d d d n # 1 swxY w Y | t# j | }~t' j | | d t- | d S )Nr r r )r rO TFr )r r r r r re r r rh r ri rB r r r r r weakrefrefgccollectassertIsr! )rm r r wrs r
test_closez_TestProcess.test_close s 9 ! ! MM7>>tyII J J J JJLL LL 0#qL B B t,,,
z
*
*
GGIII
d u--- Q'''
z
*
*
JJLLL
z
*
*
FFHHH
z
*
*
KKMMM
[^^
bbddD!!!AsH C))C-0C-F//F36F3G55G9<G9H;;H?H?walltimec L j dk r- d j t j }|dk rdnd} fdt | D }|D ]}| |D ]}t | |D ] } |j d fdt | D }|D ]}| t j d |D ]}| |D ]}t | t j d
k r^t j g}t" j d k r | t j |D ] } |j | d S d S ) Nr r rK r r& c H g | ] } j d S )){Gz?r )r r, .0rS rm s r
<listcomp>z4_TestProcess.test_many_processes.<locals>.<listcomp> s< $ $ $ T%5G DD $ $ $r r c F g | ] } j S )r )r r) rr s r rt z4_TestProcess.test_many_processes.<locals>.<listcomp> s: $ $ $ T%5 66 $ $ $r MbP?r@ darwin)r r r r rM rP r r$ rh r r r r r? r) r5 r; rw rx rU rB rj )rm smNprocsr exitcodess ` r test_many_processesz _TestProcess.test_many_processes s 9 ! ! MM7>>tyII J J J
-
/
/w AAC$ $ $ $ (($ $ $ A
GGIIII A OOOO , ,A QZ + + + +$ $ $ $ (($ $ $ A
GGIIII
5 A
KKMMMM A OOOO
7d?? . )I|x'' &. 111
5
5
aj)4444 ?
5
5r c t }t j | }| }| |||f }~| | t j | | d |
| d t | d S )Nr r )
r rg rh r r r r ri rj rk rh r r! )rm r rl r r s r test_lose_target_refz!_TestProcess.test_lose_target_ref s OO
[^^ JJLL LLAL / /
bbddD!!! !$$$Ar c z | t j | d S r )r r fd_countr/ )rm evtr s r _test_child_fd_inflationz%_TestProcess._test_child_fd_inflation s. i ""###
r c R j dk r- d j t j }|dk r( d | d} fdt | D }|D ]}| fdt | D } t t | d| |D ]}| t d S # |D ]}| t w xY w)Nr r rd r c L g | ] } j f !S r )r r )rs rS r r rm s r rt z8_TestProcess.test_child_fd_inflation.<locals>.<listcomp> s@ $ $ $ T%B#q RR $ $ $r c 8 g | ]} S rW r )rs rS r s r rt z8_TestProcess.test_child_fd_inflation.<locals>.<listcomp> s! 333Q333r r )r r r r rM r r rP r rh r r` r r! )rm rx ry rz r fd_countsr r s ` @@r test_child_fd_inflationz$_TestProcess.test_child_fd_inflation s 9 ! ! MM7>>tyII J J J
-
/
/
<<
MM7>>rBB C C C
jjll JJLL$ $ $ $ $ $ (($ $ $ A
GGIIII 3333%((333I SY 0 0!Y ? ? ?
GGIII
NNNNN
GGIII
NNNNs
A E( (>F&c fd}fd}t j | t j |d d S )Nc X t j d d S )N ?r r r` r s r func1z2_TestProcess._test_wait_for_threads.<locals>.func1 s! JsOOO GGIIIIIr c X t j d d S )N )r r clearr s r func2z2_TestProcess._test_wait_for_threads.<locals>.func2 s! JrNNN IIKKKKKr r Tr )r Threadr )rm r r r s ` r _test_wait_for_threadsz#_TestProcess._test_wait_for_threads s &&&,,...d33399;;;;;r c v | j dk r-| d | j | }| | j |f }| | | | d S )Nr r r )
r r r r r r r r r is_set)rm r procs r test_wait_for_threadsz"_TestProcess.test_wait_for_threads
s 9 ! ! MM7>>tyII J J Jjjll||4#>cV|LL
%%%%%r c | D ]K\ }}|dk r(t j }| nd }t t
|d L| d S )Nr )itemsioStringIOr setattrrw r` )rm r break_std_streams stream_nameactionstreams r _test_error_on_stdio_flushz'_TestProcess._test_error_on_stdio_flush st #4#:#:#<#< , , K Cd + + + + r c l t j d g}|d dD ] }|D ]}t t | }t t || | }| | j |f }| |
| | |
|j d t t || # t t || w xY wd S )Nr stdoutstderrr )r r r getattrrw r r r r r r r r rh r )rm streamsr r
old_streamr r s r test_error_on_stdio_flush_1z(_TestProcess.test_error_on_stdio_flush_1% s# ;==$'
/
:
:K!
:
: $S+ 6 6
[&111 : **,,C <<t/N.1V ( 5 5DJJLLLIIKKKOOCJJLL111$$T]A666Cj9999GCj9999
:
:
:s
%BDD/c dD ]}dD ]}t t | } | }| | j |||if }| | | | | |j
d t t || # t t || w xY wd S )Nr )r remover r ) r rw r r r r r r r rh r r )rm r r r r r s r test_error_on_stdio_flush_2z(_TestProcess.test_error_on_stdio_flush_28 s 0 : :K-
:
: $S+ 6 6
: **,,C <<t/N.1K3H-I ( K KDJJLLLIIKKKOOCJJLL111$$T]A666Cj9999GCj9999
: : :s B CC,r1 c V t j | | d S r r )rm r r+ s r _sleep_and_set_eventz!_TestProcess._sleep_and_set_eventI s#
5 r c | j dk r-| d | j t j }|dk r(| d | ddlm} | d}| }| | j
||f }| |j }t j || t j |dz | }| | j
|f } | | | | | | j d | | | | |j d d S )
Nr r
forkserverr ) _forkserverr r g @)r )r r r r rM multiprocessing.forkserverr ensure_runningr r r r _forkserver_pidr? rA r r r r r rh r rj )
rm signumrx r r+ r r r evt2r s
r check_forkserver_deathz#_TestProcess.check_forkserver_deathN s 9 ! ! MM7>>tyII J J J
-
/
/
MM7>>rBB C C C::::::""$$$ jjll||4#<C<|PP
)
V
53; zz|| D$=TG LL
&&& +++
%%%
dmX.....r c D | t j d S r )r r5 SIGINTr s r test_forkserver_sigintz#_TestProcess.test_forkserver_sigintt s ##FM22222r c h t j dk r!| t j d S d S r? )r? r) r r5 rB r s r test_forkserver_sigkillz$_TestProcess.test_forkserver_sigkillx s0
7d?? ' ' 7 7 7 7 7 ?r )r N)r1 )3rr rs rt r r r r requires_resourcer classmethodr r r r r r r r
r rC
skipUnlessr _HAVE_THREAD_NATIVE_IDr" r r) r, r9 r= rC rH rM rQ rX r\ ra re rm r| r~ r r r r r r r r r r r rW r r r r / s ,M 1 1 1
,
,
, W u%% &% ( [
'
'
' [
C
C
C B B [B= = =2 [
L L [L & & &P X9;LMMV V NMV $ $ [$ [ [1 1 1f4 4 48 8 8# # # 4 4 4 [+ + +( [> > > [
@ W z**!5 !5 +*!5F [ >
<
< [
<
&
&
& @B [ : : :&: : :" [$/ $/ $/L3 3 38 8 8 8 8r r c & e Zd Zd Zd Zd Zd ZdS ) _UpperCaserc t j | t j \ | _ | _ d S r )r r r~ r
child_conn parent_connr s r r~ z_UpperCaser.__init__ s7 ((...,;,@,B,B))))r c | j t | j j d D ].}| j | /| j d S r )r r iterr r r upperrm r s r runz_UpperCaser.run sp do*D11 , ,A O + + + + r c h | j | | j S r )r r r r s r submitz_UpperCaser.submit s. a $$&&&r c | j d | j | j d S r )r r r r r s r stopz_UpperCaser.stop sH d### r N)rr rs rt r~ r r r rW r r r r sS C C C ' ' '
r r c P e Zd ZdZd Zd Zed Zed Zd Z dS )_TestSubclassingProcessr c L t }d|_ | | | d d | | d d | | d S )NTr HELLOworldWORLD)r r r rh r r r )rm
uppercasers r test_subclassingz(_TestSubclassingProcess.test_subclassing s ]]
**733W=== **733W===r c X | j dk r-| d | j t j }| t j | | | j |f }| |
t |d 5 }| }|
d| |
d| |
d| d d d d S # 1 swxY w Y d S ) Nr r r utf-8encodingZeroDivisionErrorztest_multiprocessing.pyz 1/0 # MARKER)r r r r TESTFNr_ unlinkr _test_stderr_flushr r openreadrj )rm testfnr frn s r test_stderr_flushz)_TestSubclassingProcess.test_stderr_flush sD 9 ! ! MM7>>tyII J J J! (&111||4#:&|KK
&7
+
+
+ /q&&((C MM-s 3 3 3 MM3S 9 9 9 MM.# . . . / / / / / / / / / / / / / / / / / /s ;AD D#&D#c t j |t j t j z t j z }t |ddd t
_ ddz d S )Nwr Fr closefdr r )r? r O_WRONLYO_CREATO_EXCLrw r )r r fds r r z*_TestSubclassingProcess._test_stderr_flush sH
WVR[2: 5 A
B
B"cGUCCC
!r c t j |t j t j z t j z }t |ddd t
_ t j | d S )Nr r Fr )r? r r r r rw r rc )r rQ r r s r _test_sys_exitz&_TestSubclassingProcess._test_sys_exit sQ
WVR[2: 5 A
B
B"cGUCCC
r c | j dk r-| d | j t j }| t j | g ddfD ]}| | j ||f }d|_ |
t | | |j
d t |d 5 }| }d d d n # 1 swxY w Y | | t# | t% j | g d
}|D ]\ }}| | 5 | t( j | }d|_ |
t | | |j
| d d d n # 1 swxY w Y d S ) Nr r r r z ignore thisr Tr r r )))Tr )Fr )) r )r r )rW r rN )r r r r r r_ r r r r r r$ rh r r r rstriprk r? r rw rc ) rm r rQ r r contentcasesrN rW s r
test_sys_exitz%_TestSubclassingProcess.test_sys_exit sW 9 ! ! MM7>>tyII J J J! (&111
II
F D$7vv>N OOAAH
GGIII OOO QZ + + +fw///
#1&&((
#
#
#
#
#
#
#
#
#
#
#
#
#
#
# W^^ - -s6{{ ; ; ; If $ 7 7ND( 4 ((
7
7LLtL<< Q X666
7
7
7
7
7
7
7
7
7
7
7
7
7
7
7 7 7s% !DD D 8A'G++G/ 2G/ N)
rr rs rt r r r r r r r rW r r r r s| "M / / /" [ [
&7 &7 &7 &7 &7r r c z t | d r| S | dk S )Nemptyr )r4 r qsize)r s r queue_emptyr s4 q' wwyywwyyA~ r c z t | d r| S | |k S )Nfull)r4 r r )r maxsizes r
queue_fullr s4 q& $vvxxwwyyG##r c e Zd Zed Zd Zed Zd Zed Zd Z d Z
ed Z d Z d
Z
d Zd Zd
Zd ZdS )
_TestQueuec | t d D ]}| | d S )N )r/ rP r r` )r r child_can_startparent_can_continuerS s r _test_putz_TestQueue._test_put sP q A IIKKKK !!!!!r c d}| | }| }| }| | j |||f }d|_ | | t | d | t || d | d | dd | ddd | d d | d
dd |
d t j t | t | d | t || d t |j }t |j
}| t j |d d | |j d | t j |d dd | |j d | t j |d | |j d | t j |d dt( | |j t( | t j |d dt* | |j d | t j |d dt,
| |j t, | | | t | d | t || d | t5 | d S )Nr r r TFr r r r^ r r r )r r r r
r r rh r r r
put_nowaitr r rK rz ri pyqueueFullr r} TIMEOUT1TIMEOUT2TIMEOUT3r` r/ r r! )rm MAXSIZEr r r r r r s r test_putz_TestQueue.test_put s\
7
++ **,, "jjll||> *=>
U++T222 E733U;;;
!
!T
!T4
!U
!UD!!!
5 U++U333 E733T:::EI&&"5#344
',Q666 $$S[!444 ',Qt<<< $$S[!444 ',
A666 $$Z%7;;; ',Qh??? $$S[(;;; ',Qx@@@ $$S[!444 ',QhGGG $$S[(;;; """ U++T222 E733U;;; Er c | | d | d | d | d | d S )Nr r r^ r )r/ r r` r r r r s r _test_getz_TestQueue._test_getA sh
!
!
!
! !!!!!r c . | }| }| }| | j |||f }d|_ | | t | d | | t j t | t | d | |
dd d | |
d d | |
d d | | d | t | d t |j
}t |j }| t" j |d | |j d
| t" j |dd | |j d
| t" j | | |j d
| t" j |dt* | |j t* | t" j |dt, | |j d
| t" j |t. | |j t. | t3 | d S ) Nr TFr r r r r^ r r )r r r r r r rh r r` r/ r r rK r
get_nowaitrz ri r Emptyr r} r r r r r! )rm r r r r r r s r test_getz_TestQueue.test_getK s
**,, "jjll||> *=>
U++T222 """
5 U++U333
4..222 4 !,,, 1--q111 ))++Q/// U++T222EI&&"5#344
'-e444 $$S[!444 '-eT::: $$S[!444 '-444 $$Z%7;;; '-dH=== $$S[(;;; '-eX>>> $$S[!444 '-h??? $$S[(;;; Er c V t dd D ]}| | d S )Nr3 r )rP r )r r rS s r
_test_forkz_TestQueue._test_fork s4 r2 A IIaLLLL r c $ | }t d D ]}| | t j t
| | j |f }d|_ | t d D ]*}|
| | +| t j |j d | t! | d S )Nr3 r Tr F)r rP r r r rK r r r r rh r ri r r r r! )rm r rS r s r test_forkz_TestQueue.test_fork s
r A IIaLLLL
5
LLuhL ? ? r - -A UYY[[! , , , , '-E::: Er c | } | | d n%# t $ r | d Y nw xY w| d | | d | d | | d | | | d | | | d t | d S )Nr z qsize method not implementedr r r )r rh r r r r r r! rm r s r
test_qsizez_TestQueue.test_qsize s( JJLL : QWWYY * * * *" : : : MM8 9 9 9 9 9 : a A&&& a A&&& A&&& A&&&As (? A! A!c t |j d D ]/}t j t | 0d S r )r r r r rK task_done)r r objs r _test_task_donez_TestQueue._test_task_done sF t$$ C Ju
KKMMMM r c fdt d D }|D ] }d|_ | t d D ]} | |D ]} d |D ]}| t
d S )Nc J g | ] } j f S r )r r' )rs rS r rm s r rt z-_TestQueue.test_task_done.<locals>.<listcomp> s> & & & <<t';5(<KK & & &r r^ Tr3 )
JoinableQueuerP r r r r r! )rm workersr rS r s ` @r test_task_donez_TestQueue.test_task_done s ""$$& & & & & !!HH& & & AAH
GGIIIIr A IIaLLLL
A IIdOOOO A
FFHHHHEr c t j 5 d}t |dz dd 5 }| d d d d n # 1 swxY w Y t j t
j 5 t | n*# t j
$ r | d Y nw xY wd d d n # 1 swxY w Y d d d d S # 1 swxY w Y d S )N imported_by_an_imported_modulez.pyr r r zif 1:
import multiprocessing
q = multiprocessing.Queue()
q.put('knock knock')
q.get(timeout=3)
q.close()
del q
z?Probable regression on import lock contention; see Issue #22853) r temp_cwdr writer
DirsOnSysPathr? getcwd
__import__r r rf )rm module_namer s r test_no_import_lock_contentionz)_TestQueue.test_no_import_lock_contention s
!
! 3 3:KkE)3AAA
Q
,RY[[99
3
33 {++++ } 3 3 3II 2 3 3 3 3 33
3
3
3
3
3
3
3
3
3
3
3
3
3
3
3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s| C A C A C A (C >C BC$B74C6B77C: C C
C
C
C C"%C"c t j }t j }| t
j |j dd t j |z
}| |d t | d S )NTg?r )
r r r r ri r r r assertGreaterEqualr! )rm r r deltas r test_timeoutz_TestQueue.test_timeout st ! # # '-e<<< 5(
u---Ar c \ | j dk r-| d | j G d dt }t j 5 | }| | | d | |
t
j t | d d d n # 1 swxY w Y t j 5 | d }| | | d |
| d n# t $ r Y nw xY w| |
t
j | | t | d d d d S # 1 swxY w Y d S ) Nr r c e Zd Zd ZdS )F_TestQueue.test_queue_feeder_donot_stop_onexc.<locals>.NotSerializablec t r )rA r s r r zQ_TestQueue.test_queue_feeder_donot_stop_onexc.<locals>.NotSerializable.__reduce__ s $$r Nrr rs rt r rW r r NotSerializabler< s#
%
%
%
%
%r r? Tr r r )r r r objecttestr captured_stderrr r r r r
r! rh r r r )rm r? r s r "test_queue_feeder_donot_stop_onexcz-_TestQueue.test_queue_feeder_donot_stop_onexc su 9 # # MM7>>tyII J J J % % % % %f % % % \
)
)
+
+
A
EE//## $ $ $
EE$KKK OOAEE'*?E @ @ A A A NNN \
)
)
+
+
1
%%A
EE//## $ $ $
EE$KKK
A....&
OOAEE'*?E @ @ A A A OOAGGII & & & NNN sK *B C??DD(A H!2(FH!
F(%H!'F((A,H!!H%(H%c | j dk r-| d | j G d dt G fddt j j } }t j 5 |t j
}| | | d | |
t j d d d n # 1 swxY w Y | |j | |j d S )
Nr r c e Zd ZdZd Zd ZdS )K_TestQueue.test_queue_feeder_on_queue_feeder_error.<locals>.NotSerializablezMock unserializable objectc " d| _ d| _ d S NF)reduce_was_called on_queue_feeder_error_was_calledr s r r~ zT_TestQueue.test_queue_feeder_on_queue_feeder_error.<locals>.NotSerializable.__init__ s ).&8=555r c d| _ t NT)rI rA r s r r zV_TestQueue.test_queue_feeder_on_queue_feeder_error.<locals>.NotSerializable.__reduce__ s )-&$$r N)rr rs rt ru r~ r rW r r r? rF s8 , ,
>
>
>
%
%
%
%
%r r? c . e Zd ZdZe fd ZdS )E_TestQueue.test_queue_feeder_on_queue_feeder_error.<locals>.SafeQueuez1Queue with overloaded _on_queue_feeder_error hookc h t | t rt | r d|_ d S d S d S rL )r rA rJ )r r& r? s r _on_queue_feeder_errorz\_TestQueue.test_queue_feeder_on_queue_feeder_error.<locals>.SafeQueue._on_queue_feeder_error" sO q.11 @"388@;?C888@ @ @ @r N)rr rs rt ru staticmethodrP )r? s r SafeQueuerN sE C C
@
@
@
@ \
@
@
@r rR )rp Tr )r r r r@ r r r rA r rB get_contextr r r r
rI rJ )rm rR not_serializable_objr r? s @r 'test_queue_feeder_on_queue_feeder_errorz2_TestQueue.test_queue_feeder_on_queue_feeder_error s 9 # # MM7>>tyII J J J % % % % %f % % % @ @ @ @ @ @ @.4 @ @ @ / 0 0
\
)
)
+
+ B B o 9 ; ;<<<A
EE& ' ' '
EE$KKK OOAEE'*?E @ @ A A A
B B B B B B B B B B B B B B B
,>??? ,MNNNNNs A;DD "D c t j t j fD ]}| | t
d 5 | d d d d n # 1 swxY w Y | t
d 5 | d d d n # 1 swxY w Y d S )Nz is closedfoo)r r r* r assertRaisesRegexrB r r r" s r $test_closed_queue_put_get_exceptionsz/_TestQueue.test_closed_queue_put_get_exceptions6 s2 &((/*G*I*II A
GGIII''
K@@
e
''
K@@
s$ A::A> A> CC C N)rr rs rt r r
r r r r r r# r' r, r5 r9 rC rU rY rW r r r r s " " [" 9 9 9v " " ["3 3 3j [ 8 [
,3 3 3* @$O $O $OL r r c e Zd Zd Zd Zd ZdS ) _TestLockc x | }| | d | | d d | | d | t
t j f|j d S NTF)Lockrh acquirereleaseri rB r ThreadErrorrm locks r test_lockz_TestLock.test_lockC s yy{{ ... e,,e444 ... :y'<=t|LLLLLr c \ | }| | d | | d | | d | | d | | d | | d | t
t f|j d S rL )RLockrh r_ r` ri r r1 rb s r
test_rlockz_TestLock.test_rlockJ s zz|| ... ... ... ... ... ... ><8$,GGGGGr c b | 5 d d d d S # 1 swxY w Y d S r r^ r s r test_lock_contextz_TestLock.test_lock_contextT sw
YY[[ s $((N)rr rs rt rd rg rj rW r r r[ r[ A sG M M MH H H r r[ c & e Zd Zd Zd Zd Zd ZdS )_TestSemaphorec | dt | | | d | dt | | | d | dt | | | d d | dt | | | d | dt | | | d | dt | d S )Nr Tr r F)r r rh r_ r` rm sems r _test_semaphorez _TestSemaphore._test_semaphore[ s2 ''9c::: --- ''9c::: --- ''9c::: U++U333 ''9c::: --- ''9c::: --- ''9c:::::r c j | d }| | | | d | dt
| | | d | dt
| d S )Nr r r^ ) Semaphorerp rh r` r r rn s r test_semaphorez _TestSemaphore.test_semaphoreh s nnQ S!!! --- ''9c::: --- ''9c:::::r c Z | d }| | d S Nr )BoundedSemaphorerp rn s r test_bounded_semaphorez%_TestSemaphore.test_bounded_semaphorep s/ ##A&& S!!!!!r c F | j dk r-| d | j | d }t |j }| |d d | |j d | |dd d | |j d | |dt d | |j d | |dt d | |j t | |t d | |j t d S )Nr r r Fr1 Tr ) r r r rr rz r_ rh r r} r r r )rm ro r_ s r r9 z_TestSemaphore.test_timeoutx sw 9 # # MM7>>tyII J J JnnQ ,, /// $$W_c::: --u555 $$W_c::: 115999 $$W_a888 x00%888 $$W_h??? 222E::: $$W_h?????r N)rr rs rt rp rs rw r9 rW r r rl rl Y sU ; ; ;; ; ;" " "@ @ @ @ @r rl c e Zd Zedd Zd Zd Zd Zd Zd Z d Z
ed Z e j
ed
d Zed Z e j
ed
d
Zed Zd ZdS )_TestConditionNc | | | | | | d S r )r_ r` r/ )r condsleepingwokenr3 s r r z_TestCondition.f sQ '
r c t d D ]>} | |k r n,n# t $ r Y n w xY wt j t ?t j t | || d S Nr3 )rP r r r rK r )rm r| r rS s r assertReachesEventuallyz&_TestCondition.assertReachesEventually s r A
466U??E #&
Ju
5 ''t44444s $
22c 0 | j dk r |j |j z
}| |d | |j d d S # t $ r Y d S w xY wd S )Nr r )r _sleeping_countr _woken_countrh _wait_semaphorer )rm r| sleeperss r check_invariantz _TestCondition.check_invariant s 9 # #
0 : : < < - 7 7 9 9 : 1--- !5!?!?!A!A1EEEEE&
$ #s A6B
BBc | }| d }| d }| | j |||f }d|_ | | |j t j | j |||f }d|_ | | |j |
|
t j t | dt | |
| | t j t | dt | |
| | t j t | dt | | | | d S )Nr r Tr r ) Conditionrr r r r r r_ r r r r_ r r rK r r notifyr` r )rm r| r} r~ r s r test_notifyz_TestCondition.test_notify s ~~ >>!$$q!! LLdHe-DL E E DF$%1H I I I
5 ''9e<<<
5 ''9e<<<
5 ''9e<<<
T""" r c | }| d }| d t d D ]}| | j ||t
f }d|_ | | |j t j | j ||t
f }d|_ | | |j t d D ]}| t d D ]} |
dt | | t d D ]}| | j ||f }d|_ | | |j t j | j ||f }d|_ | | |j t d D ]}| t! j t$ |
dt | | | | fdd | | d S )Nr r r Tr c " t S r r r~ s r <lambda>z0_TestCondition.test_notify_all.<locals>.<lambda> Yu-=-= r )r rr rP r r r r r r_ r r r r_ r r r r r rK
notify_allr` r rm r| r} rS r r r~ s @r test_notify_allz _TestCondition.test_notify_all s ~~ >>!$$q!! q $ $A DF#'5("C E EAAH
GGIII OOAF # # # '+Xuh&GI I IAAH
GGIII OOAF # # # # q A q A MMOOOO ''9e<<<
T""" q $ $A DF$%1H IIAAH
GGIII OOAF # # # dHe5LMMMAAH
GGIII OOAF # # # # q A
5 ''9e<<<
$$%=%=%=%=qAAA
T"""""r c | }| d }| d t d D ]}| | j ||f }d|_ | | |j t j
| j ||f }d|_ | | |j t d D ]}| t j
t | dt | | d | | fdd | | d | | fd
d | | d | | dt | | d S ) Nr r r Tr r )nc " t S r r r s r r z._TestCondition.test_notify_n.<locals>.<lambda>9 r r r^ c " t S r r r s r r z._TestCondition.test_notify_n.<locals>.<lambda>@ r r )r rr rP r r r r r_ r r r r_ r r rK r r r r` r r r s @r
test_notify_nz _TestCondition.test_notify_n s6 ~~ >>!$$q!! q $ $A DF$%1H IIAAH
GGIII OOAF # # # dHe5LMMMAAH
GGIII OOAF # # # # q A
5 ''9e<<<
a
$$%=%=%=%=qAAA
a $$%=%=%=%=qAAA
a ''9e<<<
T"""""r c 2 | }t |j }| |t }| | |d | |j t d S rH ) r rz r/ r_ r r` rh r r} )rm r| r/ r s r r9 z_TestCondition.test_timeoutL s{ ~~ TY'' d8nn e$$$ $$T\8<<<<<r c |5 d_ | | fd }|r j dk rt j d d d d d S # 1 swxY w Y d S )Nr c j dk S r] r states r r z0_TestCondition._test_waitfor_f.<locals>.<lambda>Z
EKN r r^ r )r r wait_forrw rc )r r| r rV s ` r _test_waitfor_fz _TestCondition._test_waitfor_fU s
EK KKMMM]]#:#:#:#:;;F
U[A - - s AA&&A*-A*zneeds sharedctypesc | }| dd | | j |f }d|_ | |5 | fd }| | | j d d d d n # 1 swxY w Y t d D ]T}t j d |5 xj d z
c_ |
d d d n # 1 swxY w Y Ut | | |j d d S )
NrS r> r Tc j dk S Nr r r s r r z-_TestCondition.test_waitfor.<locals>.<lambda>i r r r r^ rq r )r r r r r r r r rh r rP r r r r$ r )rm r| r rV rS r s @r test_waitforz_TestCondition.test_waitfor^ s ~~
3## LL 4D%=L I I
- -]]#:#:#:#:;;F OOF # # # U[! , , , - - - - - - - - - - - - - - -
q A Jt
q
Q Q'''''s% 'A B<<C C .%D D# &D# c | |5 d}t j }| fd| }t j |z
}|s|t z
|k rd|_ d d d d S # 1 swxY w Y d S )Nr c j dk S r] r r s r r z8_TestCondition._test_waitfor_timeout_f.<locals>.<lambda>| r r r T)r` r r r CLOCK_RESr )r r| r successro rW dtrV s ` r _test_waitfor_timeout_fz&_TestCondition._test_waitfor_timeout_fv s
% % H !!B]]#:#:#:#:H]MMF !!B&B
%x) 3 : : $
% % % % % % % % % % % % % % % % % %s A BB Bc | }| dd }| dd }| d }| | j ||||f }d|_ | | | t j
t d D ]T}t j
d |5 |xj d z
c_ | d d d n # 1 swxY w Y Ut! | | |j d S )
NrS r Fr Tr r rq r )r r rr r r r r r r_ r r rP r r r r r$ )rm r| r r ro r rS s r test_waitfor_timeoutz#_TestCondition.test_waitfor_timeout sq ~~
3""**S%((nnQ LL < #UGS 9
;
; G,@ AABBB q A Ju
q
Q
&&&&&s +%D D #D c |5 | d d d n # 1 swxY w Y t j d |!t j |t
j d S d S r )r r r r? rA r5 r )r r r s r _test_wait_resultz _TestCondition._test_wait_result s
HHJJJ
1
? GC ' ' ' ' ' ?s $((c t | t r$t j dk rt j }nd }| }|5 | | d | | d | | j
||f }| | | d |!|
t |j d | d d d d S # 1 swxY w Y d S )Nr- r r r < )r ProcessesMixinrw rx r? r r r r/ r r r r ri KeyboardInterruptr )rm r r r s r test_wait_resultz _TestCondition.test_wait_result sY dN + + 0G0G)++CCC NN
QVVAYY ' ' ' QVVC[[ ) ) ) D$:!S JJA
GGIII OOAFF2JJ ' ' '!!"3QVR@@@
FFHHH s C"EEEr )rr rs rt r r r r r r r r9 r rC r HAS_SHAREDCTYPESr r r r r rW r r rz rz sK [ 5 5 5 + + +Z<# <# <#|0# 0# 0#d= = = [ X)+?@@( ( A@(. % % [% X)+?@@' ' A@'. ( ( [( r rz c 2 e Zd Zed Zd ZddZdS )
_TestEventc ` t j t | d S r )r r r r` rZ s r _test_eventz_TestEvent._test_event s#
8
r c | }t |j }| | d | |d d | |j d | |t d | |j t | | | d | | d | |j d | |t d | |j d | |
| j |f }d|_ |
| | d | d S )NFr1 Tr )r rz r/ rh r r r} r r` r r r r r r )rm r[ r/ r s r
test_eventz_TestEvent.test_event s
UZ((
///
cE*** $$T\3777 h /// $$T\8<<<
... &&& $$T\3777 h ... $$T\3777
LL 0xL @ @ &&& r returnNc 8 | }| j dk r| t | d | | t | d | | t | d d S | j dk r\| t | d | | t | d d S d S )Nr z<Event at .* unset>z<Event at .* set>r z(<EventProxy object, typeid 'Event' at .*)r r assertRegexreprr` r )rm r[ s r test_reprz_TestEvent.test_repr s
9 # # T%[[*@ A A A IIKKK T%[[*> ? ? ? KKMMM T%[[*@ A A A A A
Y)
#
# T%[[*U V V V IIKKK T%[[*U V V V V V $
#r )r N)rr rs rt r r r r rW r r r r sW [! ! !F W W W W W Wr r c , e Zd Zd Zd Zd Zd Zd ZdS )
_DummyListc t j t j d }t j }| ||f d| j d< d S )NrS r )r heap
BufferWrapperstructcalcsizer^ __setstate__
_lengthbuf)rm wrapperrc s r r~ z_DummyList.__init__ sZ !&44V_S5I5IJJ #%% 7D/*** r c |\ | _ | _ | j d | _ d S )NrS )_wrapper_lockcreate_memoryviewcastr )rm r s r r z_DummyList.__setstate__ s7 &+#
-99;;@@EEr c | j | j fS r )r r r s r __getstate__z_DummyList.__getstate__ s
tz**r c p | j 5 | j dxx dz
cc< d d d d S # 1 swxY w Y d S Nr r r r )rm _s r rU z_DummyList.append s
Z $ $ OA ! # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s +//c ^ | j 5 | j d cd d d S # 1 swxY w Y d S r r r s r __len__z_DummyList.__len__ sx
Z & &?1% & & & & & & & & & & & & & & & & & &s
"&&N)rr rs rt r~ r r rU r rW r r r r sb F F F+ + +$ $ $& & & & &r r c . t j d d S )Nrq r' rW r r _waitr
s Jtr c 8 e Zd ZdZd
dZd Zd Zd Zd Zd Z d S ) Bunchz
A bunch of threads.
Fc || _ || _ || _ | | _ | | _ | | _ |s| j g }t | D ]M}|
| j }d|_ |
| | Nd } t j | | | | _ dS )z
Construct a bunch of `n` threads running the same function `f`.
If `wait_before_exit` is True, the threads won't terminate until
do_finish() is called.
r Tc 8 | D ]}| d S r )r )r r s r finalizez Bunch.__init__.<locals>.finalize, s*
r N)r rN r DummyListstartedfinishedr _can_exitr` rP r taskr r rU rg r
_finalizer)
rm namespacer rN r wait_before_exitr rS r r s
r r~ zBunch.__init__ s **,, !++--
" ** ! N q A!!!33AAH
GGIII NN1 "*47CCr c Z t j }| j | | j | j | j | | j d d S # | j | | j d w xY w)N ) r? r r rU r rN r r r/ rm r s r r z
Bunch.task2 s ikk C + DFDI M % % % N # # # # #
M % % % N # # # * * * *s A4 46B*c t | j | j k r-t t | j | j k +d S d S r )r r r r r s r wait_for_startedzBunch.wait_for_started< sG $, $&(( GGG $, $&((((((r c t | j | j k r-t t | j | j k +d S d S r )r r r r r s r wait_for_finishedzBunch.wait_for_finished@ sG $- 46)) GGG $- 46))))))r c 8 | j d S r )r r` r s r do_finishzBunch.do_finishD s r c . | d S r )r r s r r z Bunch.closeG s r Nr )
rr rs rt ru r~ r r r r r rW r r r r s D D D D8+ + + r r c e Zd Zd Zd ZdS )
AppendTruec || _ d S r )r& )rm r& s r r~ zAppendTrue.__init__L s
r c : | j d d S rL )r& rU r s r r zAppendTrue.__call__N s r Nr rW r r r r K s2 r r c < e Zd ZdZdZdZd Zd Zd Zd Z e
d Z d d
Z d Z
e
d Zd
Ze
d Zd Ze
d Zd Ze
d Zd Ze
d Zd Ze
d Zd Ze
d Zd Zd Z e
d Z d Z d S ) _TestBarrierz$
Tests for Barrier objects.
r g >@c R | | j | j | _ d S )Nr )Barrierry defaultTimeoutbarrierr s r setUpz_TestBarrier.setUpY s" ||DFD4G|HH r c F | j d | _ d S r )r abortr s r tearDownz_TestBarrier.tearDown\ s! r c | j dk rg S | j dk r| j S t S )Nr r )r r r r r s r r z_TestBarrier.DummyList` s? 9 ! !I
Y)
#
#<$$&& & << r c t | ||| j dz
} || | | d S # | w xY wr )r ry r r )rm r rN r s r run_threadsz_TestBarrier.run_threadsh s` $4 * *
AtHH
! ! !
GGIIIIIAGGIIIIs A A!c |j }t | D ]`}|d d | |d d | ad S # t $ r Y d S w xY w)Nr Tr )partiesrP rU r/ r )r r resultsr mrS s r multipassz_TestBarrier.multipassp s Oq A AJ d # # # LLNNN AJ d # # # LLNNNN " DD s :
BBr c | | g}| | j | j ||f dS )z;
Test that a barrier is passed in lockstep
N)r r r r )rm passesr s r test_barrierz_TestBarrier.test_barrier sI >>##T^^%5%56 $,)HIIIIIr c , | d S )zC
Test that a barrier works for 10 consecutive runs
r3 )r
r s r test_barrier_10z _TestBarrier.test_barrier_10 s $$$r c X | }| | d S r )r/ r )r r r r s r _test_wait_return_fz _TestBarrier._test_wait_return_f s" llnn
#r c $ | | | j | j f fdt | j D }| | d d t dS )z9
test the return value from barrier.wait
c 8 g | ]} S rW r )rs rS r s r rt z1_TestBarrier.test_wait_return.<locals>.<listcomp> s! 6661599;;666r r r N) r r r r rP ry rh countr! )rm r r s @r test_wait_returnz _TestBarrier.test_wait_return s
1DL%3HIII6666df
666 q))1---Er c b | t | dk rt d S r )r/ r r1 )r r r s r _test_action_fz_TestBarrier._test_action_f s. w<<1 r c | }| | j t | }| | j ||f | t | d dS )z,
Test the 'action' callback
)r r N)r r ry r r r rh r )rm r r s r test_actionz_TestBarrier.test_action sr .."",,tvj.A.A,BB ,w.@AAA W q)))))r c B | }|| j dz k rt | | d d S # t j $ r | d Y d S t $ r | Y d S w xY wNr T)r/ ry r1 rU r BrokenBarrierErrorr )r r results1results2rS s r
_test_abort_fz_TestBarrier._test_abort_f s ACE1H}}"" LLNNN OOD ! ! ! ! !+ " " " OOD ! ! ! ! ! ! MMOOOOOO s AA $B = B B c v | }| }| | j | j ||f | t | d | t | | j dz
| | j j dS )zK
Test that an abort will put the barrier in a broken state
r r N) r r r r rh r ry r broken)rm r r s r
test_abortz_TestBarrier.test_abort s >>##>>## + ,(; = = = X *** X q111 +,,,,,r c | }|| j dz k rO|j | j dz
k r't j d |j | j dz
k '| nU | | d n*# t j $ r | d Y nw xY w| | d d S )Nr r rv T) r/ ry n_waitingr r resetrU r r )r r r r results3rS s r
_test_reset_fz_TestBarrier._test_reset_f s LLNN q==#ceAg--
5!!! #ceAg-- MMOOOO
& %%%% /
&
&
&%%%%%
& s 3)B $CCc | }| }| }| | j | j |||f | t | d | t | | j dz
| t | | j dS )zL
Test that a 'reset' on a barrier frees the waiting threads
r r N)r r r$ r rh r ry )rm r r r# s r
test_resetz_TestBarrier.test_reset s >>##>>##>>## + ,(HE G G G X *** X q111 X /////r c " | }|| j dz k rt | | d nI# t j $ r | d Y n#t $ r | Y nw xY w| | j dz k r| | | | d d S r )r/ ry r1 rU r r r r" )r r barrier2r r r# rS s r _test_abort_and_reset_fz$_TestBarrier._test_abort_and_reset_f s ACE1H}}"" LLNNN OOD ! ! ! !+ " " " OOD ! ! ! ! ! MMOOOOO
==??ceQh & & MMOOO
s AA $B; BBc | }| }| }| | j }| | j | j ||||f | t | d | t | | j dz
| t | | j dS )zF
Test that a barrier can be reset after being broken.
r r N)r r ry r r) r rh r )rm r r r# r( s r test_abort_and_resetz!_TestBarrier.test_abort_and_reset s >>##>>##>>##<<'' 5 ,(HhO Q Q Q X *** X q111 X /////r c | }|| j dz k rt j d | d d S # t j $ r | d Y d S w xY w)Nr ?r T)r/ ry r r r r rU r r r rS s r _test_timeout_fz _TestBarrier._test_timeout_f s LLNN q== JsOOO ! LL + ! ! ! NN4 !s A $A76A7c | }| | j | j |f | t | | j j dS )z$
Test wait(timeout)
N)r r r/ r rh r r )rm r s r r9 z_TestBarrier.test_timeout sZ .."" - g/FGGG W t|';<<<<<r c | | j }|| j dz k rt j d | d S # t
j $ r | d Y d S w xY w)Nr r- T)r/ r ry r r r r rU r. s r _test_default_timeout_fz$_TestBarrier._test_default_timeout_f s LL+ , , q== JsOOO ! LLNNNNN+ ! ! ! NN4 !s A $A<;A<c | | j d }| }| | j ||f | t
| |j dS )z4
Test the barrier's default timeout
r r N)r ry r r r2 rh r r )rm r r s r test_default_timeoutz!_TestBarrier.test_default_timeout' sl ,,tvs,33.."" 57IJJJ W w77777r c | d }| | d S r )r r/ )rm r s r test_single_threadz _TestBarrier.test_single_thread0 s/ LLOO r c t | D ]E}| |5 | | d d d n # 1 swxY w Y Fd S r )rP r/ r )r r r connrc rS s r _test_thousand_fz _TestBarrier._test_thousand_f5 s v A LLNNN
!
s A
A A c H | j dk r-| d | j d}| }| d \ }}t | j D ]U}| | j | j |||f }|
| |j Vt | D ]A}t | j D ]*}|
| | +Bd S )Nr r Fr )r r r r^ r rP ry r r9 r r r_ r rh r )rm r rc r8 r jr rS s r
test_thousandz_TestBarrier.test_thousand< s 9 ! ! MM7>>tyII J J Jyy{{ 99U++jtv $ $A D$9!% vz4 H J JA
GGIII OOAF # # # #v 1 1A46]]
1
1 a0000
1 1 1r Nr ) rr rs rt ru ry r r r r r r r r
r r r r r r r r$ r& r) r+ r/ r9 r2 r4 r6 r9 r= rW r r r r R s
ANI I I " " [" J J J J% % % [ [
* * *
[
-
-
- [ " 0 0 0 [ *
0
0
0 ! ! [!= = = ! ! [!8 8 8
[ 1 1 1 1 1r r c z e Zd ZdZddddd ed ed fgZd Zed
Zdd Z d
Z
d Z dS )
_TestValuer )rS i i^ )dg
@g )hi )r r xyc B t s| d d S d S Nz%requires multiprocessing.sharedctypesr r r s r r z_TestValue.setUp\ 0 C MMA B B B B B C Cr c V t || j D ]\ }}|d |_ d S ru )zip codes_valuesr )r valuessvcvs r r z_TestValue._test` s9 &#"233 FB!uBHH r Fc |r fd j D }n fd j D }t | j D ]&\ }} |j |d ' j |f }d|_ | | t | j D ]&\ }} |j |d 'd S )Nc D g | ] \ }}} || S rW )RawValuers coder r rm s r rt z)_TestValue.test_value.<locals>.<listcomp>h s= ? ? ?($q mmD%00 ? ? ?r c D g | ] \ }}} || S rW )r rT s r rt z)_TestValue.test_value.<locals>.<listcomp>k s= ? ? ?($q jju-- ? ? ?r r r Tr ) rM rL rh r r r r r r )rm rawrN rO rP r s ` r
test_valuez_TestValue.test_valuef s' ?? ? ? ?,0,=? ? ?FF? ? ? ?,0,=? ? ?F &$"344 . .FB RXr!u - - - -||4:VI|>>
&$"344 . .FB RXr!u - - - - . .r c 2 | d d S NT)rW )rX r s r
test_rawvaluez_TestValue.test_rawvaluey s D!!!!!r c | dd }| }| }| ddd }| }| }| }| dd| }| } | }
| || | ddd } | t
| d | t
| d | t | j ddd | dd } | t
| d | t
| d d S )NrS r rc Fget_lockget_objnavalue)
r r^ r_ r^ rh r r4 ri rA rS )
rm val1lock1obj1val2lock2obj2rc val3lock3obj3arr4arr5s
r test_getobj_getlockz _TestValue.test_getobj_getlock| s} zz#q!!
||~~zz#qtz,,
||~~yy{{zz#qtz,,
||~~ u%%%zz#quz-- z22333 y11222 .$*c19MMM}}S!$$ z22333 y1122222r Nr ) rr rs rt r r rM r r r rX r[ rl rW r r r? r? P s "M eeCjj%%**%
LC C C [
. . . .&" " "3 3 3 3 3r r? c
e Zd ZdZed Z ej edu d d
d Z ej edu d d Z
ej edu d d Z ej edu d d Z dS )
_TestArrayr c x t dt | D ]}||xx ||dz
z
cc< d S r )rP r )r seqrS s r r z _TestArray.f sK q#c((## A FFFc!A#h FFFF r Nzrequires _ctypesFc D g d}|r| d| }n| d| }| t | t | | |d |d | t |dd t |dd t j dg d x|dd< |dd< | t |d d | | | | | j |f }d
|_ | |
| t |d d | d S ) N)
i ir i i5 i$ i i i? rS r r r
)r r r r^ r^ r r T) RawArrayArrayrh r r arrayr r r r r )rm rW rp arrr s r
test_arrayz_TestArray.test_array sp @@@ '--S))CC**S#&&C S3s88,,, QQ((( c!A#h c!A#h 888 #k#||| < <<AaC3qs8 c!!!f s+++ s LLcVL 4 4 c!!!f s+++++r c d}t d D ]}| d| }| t | | | t | dg|z t d |d d < | t | t t d ~d S )Nr3 r rS r )rP ru rh r r )rm sizer rw s r test_array_from_sizez _TestArray.test_array_from_size s
q A**S$''C SXXt , , , T#YYd
3 3 32YYCF T#YYU2YY 8 8 8
r c 2 | d d S rZ )rx r s r
test_rawarrayz_TestArray.test_rawarray s D!!!!!r c | | dt t d }| }| }| dt t d d }| }| }| }| dt t d | }| } | }
| || | dt d d } | t | d | t | d | t | j dt d d | dt d } | t | d | t | d d S )NrS r3 r] Fr^ r_ notalock) ru r rP r^ r_ r^ rh r r4 ri rA rt )
rm arr1rb rc arr2re rf rc arr3rh ri rj rk s
r test_getobj_getlock_objz"_TestArray.test_getobj_getlock_obj s zz#tE"II//
||~~zz#tE"IITz::
||~~yy{{zz#tE"IITz::
||~~ u%%%zz#uRyyuz55 z22333 y11222 . *c599: G G G }}S%)),, z22333 y1122222r r )
rr rs rt r r r rC rv r9 rx r{ r} r rW r r rn rn s "M [ X_Ud]$677, , , 87,0 X_Ud]$677 87 X_Ud]$677" " 87" X_Ud]$6773 3 873 3 3r rn c B e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d Z d
S ) _TestContainersr c | t t d }| |d d t t d | }| |d d g | t t d | |d d t t d | |d d | |dd g d |dz }| |d d g d | |ddgz g d | |d d t t d ||g}| | }| d |D g d g dg | |g }| d
| |d d d g d d S )
Nr3 r r )r r r^ )
r r r r r^ r r r r r^ r ) r r r r r^ r r r r r^ r r c " g | ] }|d d
S r rW )rs elements r rt z-_TestContainers.test_list.<locals>.<listcomp> s ) ) )GWQQQZ ) ) )r )
r r r r r^ r r r
r r r ) r r r r r^ r r r
r r r )r rP rh extendrU )rm r r r@ r r s r test_listz_TestContainers.test_list s IId599oo & & 111tE"II/// IIKK 111r""" eAhh 111tE!HH~~... 1q!!! 1R4'''*** Q 111 = = =>>> aV%I%I%IJJJ 111tE"II///
F IIaLL ) )q ) ) )
+
+
+-K-K-K L
IIqcNN 1aaa"I"I"IJJJJJr c | t t d }t | }| t | t t d | t | g t | }d|d< | t | d d S )Nr3 r& r )r rP r rh next)rm r its r test_list_iterz _TestContainers.test_list_iter s IId599oo & &
!WW b4b ??333 b2&&&
!WW! b3'''''r c fdt d D } d |D g dgdz d|d d< |d d d g d t d d D ](} || d d g d ) |d d
t |d d
t ddd
D ]+} t || d ,~ }| | ~d S ) Nc T g | ]$} t d %S )r )r rP )rs _irm s r rt z;_TestContainers.test_list_proxy_in_list.<locals>.<listcomp> s+ >>>rtyyq**>>>r r c " g | ] }|d d
S r rW )rs inners r rt z;_TestContainers.test_list_proxy_in_list.<locals>.<listcomp> s 222u%(222r )r r r 7 r r> )r r r r r )r rP rh popr rU )rm r rS r s ` r test_list_proxy_in_listz'_TestContainers.test_list_proxy_in_list su II>>>>U1XX>>> ? ? 22222YYYK!ODDD!R 1aaa***---q! 1 1A QqT!!!Wiii 0 0 0 0 1Q''' QqTA&&&q!Q + +A S1YY * * * *
IIKK
AAr c z | }t t dd }|D ]}t | ||< | | t d |D | t
| | | t
| d |D | t
| d |D d S )NA F c 3 8 K | ]}|t | fV d S r chrrs rS s r <genexpr>z,_TestContainers.test_dict.<locals>.<genexpr>/ s, 'E'ECFF 'E'E'E'E'E'Er c , g | ]}t | S rW r r s r rt z-_TestContainers.test_dict.<locals>.<listcomp>1 s -F-F-Fc!ff-F-F-Fr c 0 g | ]}|t | fS rW r r s r rt z-_TestContainers.test_dict.<locals>.<listcomp>2 s" ,J,J,JQaQ[,J,J,Jr )
dictr rP r rh r sortedkeysrN r )rm r@ indicesrS s r test_dictz_TestContainers.test_dict* s IIKKuR}}%% Aq66AaDD 4'E'EW'E'E'E#E#EFFF ))7333
++-F-Fg-F-F-FGGG **,J,J',J,J,JKKKKKr c | }t t dd }|D ]}t | ||< t | }| t | | | t | g t | }| | t t | d S )Nr r )
r r rP r r rh r ri r1 r )rm r@ r rS r s r test_dict_iterz _TestContainers.test_dict_iter4 s IIKKuR}}%% Aq66AaDD
!WW b7+++ b2&&&
!WW ,b11111r c " | dd }| dd }| || }| |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 d | |d d d | | t | d | |d d | |d d | ||g }d|d d< | |d d | |d d d ~~| |d d d | ddg|g }| |d t | |d d d d d S )Nr r^ )ferretshamstersr3 r )waterfeed)petssuppliesr r r blanketsr
r r r r r marmotsX c r> r )r rh r r r r )rm r r r@ louters r test_dict_proxy_nestedz&_TestContainers.test_dict_proxy_nestedA s yyQy//992A9.. II4(I 3 3 '*B/// : w/444$%*
j! *-q111 : z2A666!"*
g '*A... : w/333 69-q111$&*
j! : z2B777yZ= '*A... : w/333 Q### '*A... j)1--- IItX& ' '!Y i !,,, 1i !,,, 1i !,,, B8Q-(( eAh--- r2 v.22222r c | }| | |d d | |d d | }| |d< |d d | |d d d S )Nr { )r rU r r rh r r r s r test_nested_queuez!_TestContainers.test_nested_queueo s IIKK !
1S))) IIKKzz||! !
1S)))))r c t | }d|_ d|_ d|_ | |j |j fd |`| t | d | t |d | t |d d S )NBobBuilderhidden)r r zNamespace(name='Bob')r) job) Namespacer) r _hiddenrh rk r r4 )rm r s r test_namespacez _TestContainers.test_namespacey s NN !&!% *<===
E Q!8999 6**+++ GAu - --.....r N) rr rs rt r r r r r r r r r rW r r r r s M K K K>( ( ( (L L L 2 2 2,3 ,3 ,3\* * * / / / / /r r r1 c d |t j | n| | | | z S r )r r r/ )rE r/ r[ s r sqrr s5 }
4
4 Q3Jr c | |z S r rW )rE rF s r mulr Q3Jr c N t j | t ddz )NrE i )r r rB r. s r raise_large_valuerrorr s$ Jt
S7]
#
##r c | S r rW rE s r identityr s Hr c e Zd ZdZd Zd ZdS )
CountedObjectr c V | xj dz
c_ t | S r ) n_instancesr@ __new__r( s r r zCountedObject.__new__ s$ 1 ~~c"""r c @ t | xj dz c_ d S r )r r r s r __del__zCountedObject.__del__ s" T
!# r N)rr rs rt r r r rW r r r r s7 K# # #$ $ $ $ $r r c e Zd ZdS ) SayWhenErrorNrr rs rt rW r r r r s r r c # K |dk rt d t | D ]}||k rt d |V d S )Nr> zSomebody said when)r rP )totalwhenrS s r exception_throwing_generatorr s` rzz/000
5\\ 99 344 4 r c
e Zd Ze fd Ze fd Zd Zd Zd Zd Z d Z
d Z d Z d
Z
d Zd Zd
Zd Zd Zd Zd Zd Zd Zd Zd Zed Zd Zed Zd Z d Z d Z d Z d Z xZ!S ) _TestPoolc | t | d | _ d S r] )super
setUpClassPoolpoolr __class__s r r z_TestPool.setUpClass s.
88A;;r c | j | j d | _ t d S r )r r r r
tearDownClassr s r r z_TestPool.tearDownClass sI
r c | j j }| |t d t d | |t dddi t d d S )N)r r rW rE r r )r applyrh r )rm papplys r
test_applyz_TestPool.test_apply si T**CFF333 R#a113888<<<<<r c
| j j }| |t t t d t t t t t d | |t t t d d t t t t t d d S )Nr3 r& r chunksize)r maprh r r rP )rm pmaps r test_mapz_TestPool.test_map s y} c4b ??33T#c4b ??:S:S5T5TUUU c4c
#3#3rBBB c#tE#JJ'7'7 8 899 ; ; ; ; ;r c
. | j j }t t t d t ddd }| |t | t t j t | t t t d t ddd }| |t |d t t j t | d S )Nr3 r r> r& r r r )r starmapr rL rP rh r r )rm psmaptupless r test_starmapz_TestPool.test_starmap s !c%))U1R__5566 sF++ i /V < <== ? ? ?c%**eBr2&6&67788 sFb999 i /V < <== ? ? ? ? ?r c
N t t t d t ddd }| | j t | t t j t | d S )Nr& r r> )
r rL rP rh r
starmap_asyncr r r r )rm r s r test_starmap_asyncz _TestPool.test_starmap_async s c%**eBr2&6&67788 00f==AACC i /V < <== ? ? ? ? ?r c
: | | j t t t d t t t t t d d S r )rh r map_asyncr r rP r r r s r test_map_asyncz_TestPool.test_map_async sq ,,S$uRyy//BBFFHH c#tE"II 7 788 : : : : :r c Z | j dk r| j ng }| j t
dg|j |j | dt | | dg|d | j t
dg|j |j | dt | |
|d t d S )Nr 1)callbackerror_callbackr r r r ) r r r r r rF rU r/ rh r r rB )rm call_argss r test_map_async_callbacksz"_TestPool.test_map_async_callbacks s +/9 +A+ADL%%'''r C#%.%5+4+; = ==ATVVV C NN+++ !il+++ C#%.%5+4+; = ==ATVVV C NN+++ ilJ77777r c Z | j dk r-| d | j G d dt }| t
5 | j t | gdz d d d d S # 1 swxY w Y d S )Nr r c e Zd Zd ZdS )*_TestPool.test_map_unplicklable.<locals>.Ac t d )Nz
cannot pickler0 r s r r z5_TestPool.test_map_unplicklable.<locals>.A.__reduce__ s "?333r Nr> rW r r Ar s#
4
4
4
4
4r r r3 ) r r r r@ ri r1 r r r )rm r s r test_map_unplicklablez _TestPool.test_map_unplicklable s 9 ! ! MM7>>tyII J J J 4 4 4 4 4 4 4 4
|
,
, ) ) IMM#uRx ( ( ( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )s &-B B$'B$c | j t g d t d S # t
j $ r | d Y d S w xY w)Nr r r z2pool.map_async with chunksize stalled on null list)r r r r r r TimeoutErrorrf r s r test_map_chunksizez _TestPool.test_map_chunksize sz L I R1 5 5 9 9( 9 K K K K K + L L L IIJ K K K K K K Ls ;? $A'&A'c D | j dk r-| d | j | t 5 | j t t dd d d d d n # 1 swxY w Y | t 5 | j t t dd d d d d n # 1 swxY w Y | t 5 | j t t dd d d d d n # 1 swxY w Y G d d }| t 5 | j t | d d d d n # 1 swxY w Y | t 5 | j t | d d d d d S # 1 swxY w Y d S ) Nr r r r> r3 r c e Zd Zd Zd Zd ZdS )E_TestPool.test_map_handle_iterable_exception.<locals>.SpecialIterablec | S r rW r s r __iter__zN_TestPool.test_map_handle_iterable_exception.<locals>.SpecialIterable.__iter__
s r c t r )r r s r __next__zN_TestPool.test_map_handle_iterable_exception.<locals>.SpecialIterable.__next__
s ""r c dS r rW r s r r zM_TestPool.test_map_handle_iterable_exception.<locals>.SpecialIterable.__len__
s qr N)rr rs rt r r r rW r r SpecialIterabler
sA
#
#
#
r r ) r r r ri r r r r r )rm r s r "test_map_handle_iterable_exceptionz,_TestPool.test_map_handle_iterable_exception sZ 9 ! ! MM7>>tyII J J J
|
,
, G G IMM# ;Ar B BA F F F G G G G G G G G G G G G G G G
|
,
, G G IMM# ;Ar B BA F F F G G G G G G G G G G G G G G G
|
,
, G G IMM# ;B B BA F F F G G G G G G G G G G G G G G G
|
,
, 5 5 IMM# 0 0! 4 4 4 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5
|
,
, 5 5 IMM# 0 0! 4 4 4 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5sZ 0BBB40C00C47C40EEE*F99F= F= *HH Hc | j t dt f }t |j }| | d | |j t d S )Nr
1 ) r apply_asyncr r rz r rh r r} )rm r r s r
test_asyncz_TestPool.test_async
sf i##C!X 88CG$$ ### $$S[(;;;;;r c | d } | j dk rt j nd }| t
dt t j z |f }t |j
}| t j
|t | |j t || | | d S # || | | w xY w)Nr r r r )r r r r r r r r r
rz r ri r r
r r} r` r r )rm r r[ r r s r test_async_timeoutz _TestPool.test_async_timeout
s IIaLL
)-i)?)?IO%%%TE--aG4I)I5%QRRC ((C o :C R R R ( (h ? ? ?
KKMMM
FFHHHHH
KKMMM
FFHHHHs
B+D A Ec
| j t t t d }| t | t t
t t t d | j t t t d }t d D ](}| t | ||z )| t |j
| j t t t d d }t d D ](}| t | ||z )| t |j
d S Nr3 r; r& r ) r imapr r rP rh r r ri
StopIterationr rm r rS s r test_imapz_TestPool.test_imap$
sK
Y^^CeBii
1
1 b4CeBii (A(A#B#BCCC
Y^^CeBii
1
1r , ,A T"XXqs + + + + -555
Y^^CeDkk!2!2c^
B
Bt , ,A T"XXqs + + + + -55555r c | j dk r-| d | j | j t
t
dd d }| t |j | j t
t
dd d }| t |j | j t
t
dd d }t d D ](}| t | ||z )| t |j | j t
t
dd d }t d
D ](}| t | ||z )| t |j | j t
t
dd d }t d D ](}| t | ||z )| t |j d S ) Nr r r r> r3 r r r
r r r^ )
r r r r r r r ri r r rP rh r r s r #test_imap_handle_iterable_exceptionz-_TestPool.test_imap_handle_iterable_exception2
s 9 ! ! MM7>>tyII J J J Y^^C!=a!D!Da
H
H , 444
Y^^C!=a!D!Da
H
H , 444
Y^^C!=b!!D!Da
H
Hq , ,A T"XXqs + + + + , 444 Y^^C!=b!!D!Da
H
Hq , ,A T"XXqs + + + + , 444
Y^^C!=b!!D!Da
H
Hq , ,A T"XXqs + + + + , 44444r c
f | j t t t d }| t
| t t t t t d | j t t t d d }| t
| t t t t t d d S r )r imap_unorderedr r rP rh r r )rm r s r test_imap_unorderedz _TestPool.test_imap_unorderedL
s
Y
%
%c4b ??
;
; T#c4b ??*C*C%D%DEEE
Y
%
%c4d +<+<
%
L
L T#c4d 3D3D*E*E%F%FGGGGGr c
\ | j dk r-| d | j | j t
t
dd d }| t |j | j t
t
dd d }| t |j | j t
t
dd d }t t t
t t d }| t 5 t d D ]<}t | }| || | | = d d d n # 1 swxY w Y | j t
t
dd d }t t t
t t d }| t 5 t d D ]<}t | }| || | | = d d d d S # 1 swxY w Y d S )
Nr r r r> r3 r r r
r )r r r r r% r r ri r r r r rP r rj r )rm r expected_valuesrS r s r -test_imap_unordered_handle_iterable_exceptionz7_TestPool.test_imap_unordered_handle_iterable_exceptionS
s 9 ! ! MM7>>tyII J J J Y
%
%c&B1b&I&I&') )
, 444
Y
%
%c&B1b&I&I&') )
, 444
Y
%
%c&B2q&I&I&') ) s3U2YY 8 899
|
,
, . .2YY
.
. R
e_555 &&u----
. . . . . . . . . . . . . . . . Y
%
%c&B2q&I&I&') ) s3U2YY 8 899
|
,
, . .2YY
.
. R
e_555 &&u----
. . . . . . . . . . . . . . . . . . .s& A
F66F:=F:A
J!!J%(J%c | j dk rt nt }| || j d | || j d | j dk r| d } | dt
|j | | d S # | | w xY wd S )Nr r> r r )
r RemoteErrorrB ri r rh r _poolr r )rm expected_errorr s r test_make_poolz_TestPool.test_make_poolw
s )-i)?)?++ )
.$)R888 .$)Q777 9 ! ! ! A
CLL111
" !s 3(C *C/c | d }d t d D }| t j |d }| | d S )Nr c & g | ]}t j S rW )r r r s r rt z,_TestPool.test_terminate.<locals>.<listcomp>
s <<<$<<<r i' r r )r rP r r r r r )rm r rN rV s r r= z_TestPool.test_terminate
sa IIaLL<<eFmm<<<TZ;;
r c P | d }| | t g g | t | t g g | t | t g g | | t g g | |
d S r ) r rh r r r r r% r r r r rL s r test_empty_iterablez _TestPool.test_empty_iterable
s IIaLL sB ,,, affS"oo..333 a . .sB 7 788"=== S"--1133R888 r c | j dk rt t d }d |D }| d 5 }| t
| }| | | d d d n # 1 swxY w Y | | t |j t
| d S d S )Nr r3 c , g | ]}t | S rW )r r s r rt z*_TestPool.test_context.<locals>.<listcomp>
s ***1A***r r ) r r rP r r r rh r r ri rB )rm LrW r rs r test_contextz_TestPool.test_context
s 9 # #U2YYA*****H1
4KKQ'' (333
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4
FFHHH j!+sA > > > > > $ #s ABB B c t d )Nr r0 r( s r _test_tracebackz_TestPool._test_traceback
s 3 r c D | j dk r| d 5 } | | j | d n# t
$ r }|}Y d }~nd }~ww xY wd d d n # 1 swxY w Y | | t | t |
|j d |j }| t | t j j | d|j t$ j 5 } |# t $ r" t+ j t+ j Y nw xY w d d d n # 1 swxY w Y | d| | d 5 } | t4 t7 dd d | d n# t
$ r }|}Y d }~nd }~ww xY w| t | t8 | |j d d d d n # 1 swxY w Y | d S d S )Nr r zexpected RuntimeError)r z&raise RuntimeError(123) # some commentr> zexpected SayWhenError) r r r r9 rf re r rk r r1 rh rN __cause__r r RemoteTracebackrj tbrA r rB rw
excepthookexc_infogetvaluer r r r )rm r r exccausef1s r test_tracebackz_TestPool.test_traceback
sA 9 # #1
77GGD 0111 II 56666 ! CCCCCC
7
7
7
7
7
7
7
7
7
7
7
7
7
7
7
FFHHH MM$s))\ 2 2 2 SXv . . .ME MM$u++';'K L L L MMBEH M M M --//
424 I# 4 4 4NCLNN333343
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4
MMB ++--
)
)
) 1
37EE# ;Ar B BAFFF II 56666 ! CCCCCC
d3ii 666
cmT222
3
3
3
3
3
3
3
3
3
3
3
3
3
3
3
FFHHHHHC $ #s A9AA9
A* A% A9%A**A99A= A=
F
E)E=:F
<E==F
FFI?*HI?
H-!H(#I?(H--AI??JJc t d )NrW r0 r( s r _test_wrapped_exceptionz!_TestPool._test_wrapped_exception
s 5!!!r c | d 5 }| t 5 | | j d d d n # 1 swxY w Y d d d n # 1 swxY w Y | d S r )r ri r1 r rF r rL s r test_wrapped_exceptionz _TestPool.test_wrapped_exception
s
YYq\\ 6Q""<00
6
64555
6
6
6
6
6
6
6
6
6
6
6
6
6
6
6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6
s4 A/A A/A A/ A A//A36A3c x t j }| t 5 | d 5 } | t ddg t j d | | nA# t j d | | w xY w d d d n # 1 swxY w Y d d d n # 1 swxY w Y |
t j |z
d d S )Nr r r r g?) r r ri rB r r r r r r
assertGreater)rm t_startr s r test_map_no_failfastz _TestPool.test_map_no_failfast
s .""
z
*
* 1
EE/!Q888JsOOOGGIIIFFHHHH JsOOOGGIIIFFHHHHH
4>++g5s;;;;;sM DC. B #=C. >C C." D.C2 2D5C2 6DD D c d t d D }d |D }| j t | ~t j t
j t | t d |D d h | t j d d S )Nc * g | ]}t S rW )r r s r rt z4_TestPool.test_release_task_refs.<locals>.<listcomp>
s 333A
333r r3 c 6 g | ]}t j | S rW )rg rh )rs os r rt z4_TestPool.test_release_task_refs.<locals>.<listcomp>
s ---1 A---r c 3 * K | ]} | V d S r rW )rs rl s r r z3_TestPool.test_release_task_refs.<locals>.<genexpr>
s( 1 1bRRTT 1 1 1 1 1 1r r )
rP r r r ri rj r r rK rh r` r r )rm objsrefss r test_release_task_refsz _TestPool.test_release_task_refs
s 43r333-----
h%%%
5 1 1D 1 1 111D6:::
2A66666r c h | j dk r| d | d }|5 d d d n # 1 swxY w Y | t 5 |5 d d d n # 1 swxY w Y d d d n # 1 swxY w Y | d S )Nr test not applicable to managerr )r r r ri rB r rm r s r
test_enterz_TestPool.test_enter
sk 9 ! ! MM: ; ; ;yy||
z
*
*
sG AA
A
+B.A<0 B<B BB BBBc ~ | j dk r| d | d }| | t
j j |_ t j
dt f 5 d }t j
d d d d S # 1 swxY w Y d S )Nr rV r z%unclosed running multiprocessing pool)r r r r r r r RUN_stater
check_warningsResourceWarningr
gc_collectrW s r test_resource_warningz _TestPool.test_resource_warning s 9 ! ! MM: ; ; ;yy|| &*.
+8/JL L ! !D ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !s B22B69B6)"rr rs rt r r r r r r r r r r r r r r r! r# r& r) r. r= r2 r7 r9 rD rF rH rL rT rX r_
__classcell__r s @r r r s [ [ = = =
; ; ; ? ? ?? ? ?
: : : 8 8 8) ) )L L L 5 5 54< < < 6 6 6 5 5 54H H H". ". ".H
? ? ? [ $ $ $L " " [" < < <(
7
7
7 ! ! ! ! ! ! !r r c t d )Nkey)KeyErrorrW r r raisingre s
5//r c d S )Nc dS )N* rW rW r r r z%unpickleable_result.<locals>.<lambda> s 2 r rW rW r r unpickleable_resultri s
:r c e Zd ZdZd Zd ZdS )_TestPoolWorkerErrorsr c t j d }d gfd}| t | }| t
|j | d | d t
| |
d S )Nr c | d< d S r rW rA
scratchpads r errbackz@_TestPoolWorkerErrors.test_async_error_callback.<locals>.errback) s JqMMMr r r ) r r r re ri rd r r r r r )rm r rp r ro s @r test_async_error_callbackz/_TestPoolWorkerErrors.test_async_error_callback% s # #V
mmGGm<< (CG,,,
1
&&& jmX666 r c ddl m} t j d }t d D ]}d gfd}| t | }| ||j d }| | |
d | | |j | |j
| | d S )Nr )MaybeEncodingErrorr r c | d< d S r rW rn s r rp z?_TestPoolWorkerErrors.test_unpickleable_result.<locals>.errback< s #
1
r rq )multiprocessing.poolrt r r rP r ri ri r r r assertIsNotNonerA r r r )rm rt r iterationrp r wrappedro s @r test_unpickleable_resultz._TestPoolWorkerErrors.test_unpickleable_result4 s ;;;;;; # # r 0 0I J
$
$
$
$
$ -- 3G-LLC 0#' : : : mG OOG $ $ $ ! !*Q-1C D D D - - - / / / / r N)rr rs rt r rr rz rW r r rk rk " s7 #M
r rk c * e Zd ZdZd Zd Zd Zd ZdS )_TestPoolWorkerLifetimer c t j dd }| dt |j d |j D }g }t d D ]1}| | t |f 2t | D ]:\ }}| |
t | ;| d}|r\t d |j D s>|dz }t j t |r t d |j D >d |j D }| d | | d | | t% | t% | | | d S )
Nr r3 maxtasksperchildc g | ] }|j
S rW r rs r s r rt zE_TestPoolWorkerLifetime.test_pool_worker_lifetime.<locals>.<listcomp>P s 111A!%111r r& 2 c 3 > K | ]}| V d S r r r s r r zD_TestPoolWorkerLifetime.test_pool_worker_lifetime.<locals>.<genexpr>^ s* #B#BQAJJLL#B#B#B#B#B#Br r c g | ] }|j
S rW r r s r rt zE_TestPoolWorkerLifetime.test_pool_worker_lifetime.<locals>.<listcomp>a s 222Q15222r )r r rh r r, rP rU r r enumerater _repopulate_poolallr r rK r r r r r ) rm r origworkerpidsr rS r< r countdownfinalworkerpidss r test_pool_worker_lifetimez1_TestPoolWorkerLifetime.test_pool_worker_lifetimeM s R 8 8 8 CLL)))11111s 6 6A NN1==qe44 5 5 5 5 "'** 0 0HQ SWWYYA / / / / #B#B!'#B#B#B B B NI Ju #B#B!'#B#B#B B B 32!'222 ~... /// F> 2 2F?4K4KLLL r c t j dd }g }t d D ]2}| | t
|df 3| | t | D ]:\ }}| |
t | ;d S )Nr r r~ r g333333?) r r rP rU r r r r r rh r )rm r r rS r< r s r %test_pool_worker_lifetime_early_closez=_TestPoolWorkerLifetime.test_pool_worker_lifetime_early_closej s
Q 7 7 7q 9 9A NN1==q#h77 8 8 8 8 !'** 0 0HQ SWWYYA / / / / 0 0r c dD ]J}| t 5 t j d| d d d n # 1 swxY w Y Kd S )N)r r> r 12r r~ )ri rB r r )rm r s r "test_pool_maxtasksperchild_invalidz:_TestPoolWorkerLifetime.test_pool_maxtasksperchild_invalidw s ' @ @E"":..
@
@ $Q????
@
@
@
@
@
@
@
@
@
@
@
@
@
@
@ @ @s AA A c d}t j j d| \ }}}| |d d S )Na if 1:
from multiprocessing import Pool
problem = None
class A:
def __init__(self):
self.pool = Pool(processes=1)
def test():
global problem
problem = A()
problem.pool.map(float, tuple(range(10)))
if __name__ == "__main__":
test()
-cr )rA r r assert_python_okrh rm cmdrd outrn s r >test_worker_finalization_via_atexit_handler_of_multiprocessingzV_TestPoolWorkerLifetime.test_worker_finalization_via_atexit_handler_of_multiprocessing| sG |1BB4MM C Q r N)rr rs rt r r r r r rW r r r| r| J sX #M : 0 0 0@ @ @
r r| ) BaseManager BaseProxyr+ c e Zd Zd Zd Zd ZdS )FooBarc dS )Nf()rW r s r r zFooBar.f s ur c t r )rB r s r gzFooBar.g s r c dS )N_h()rW r s r _hz FooBar._h s vr N)rr rs rt r r r rW r r r r sA r r c # < K t d D ] } | | z V
d S r )rP )rS s r bazr s4
2YY c r c e Zd ZdZd Zd ZdS )
IteratorProxy)r c | S r rW r s r r zIteratorProxy.__iter__ s r c , | d S )Nr ) _callmethodr s r r zIteratorProxy.__next__ s
+++r N)rr rs rt _exposed_r r rW r r r r s7 I , , , , ,r r c e Zd ZdS ) MyManagerNr rW r r r r s Dr r Foo)callableBar)r r )r exposedr )r proxytypec * e Zd ZdZd Zd Zd Zd ZdS )_TestMyManagerr c t t }| | | | | |j j dt j f d S N)shutdown_timeoutr )
r SHUTDOWN_TIMEOUTr commonshutdownrj _processr r5 r; rm r s r test_mymanagerz _TestMyManager.test_mymanager so -=>>>
G
g&/!fn_1EFFFFFr c t t }|5 | | d d d n # 1 swxY w Y | |j j dt j f d S r )r r r rj r r r5 r; r s r test_mymanager_contextz%_TestMyManager.test_mymanager_context s -=>>>
! ! KK ! ! ! ! ! ! ! ! ! ! ! ! ! ! !
g&/!fn_1EFFFFFs
:>>c t t }| |5 | | d d d n # 1 swxY w Y | |j j d d S r )r r r r rh r r r s r !test_mymanager_context_prestartedz0_TestMyManager.test_mymanager_context_prestarted s -=>>>
! ! KK ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! )2A66666s AAAc | | | }fddD }fddD }| |ddg | |ddg | d | t j | d d | t j d | d |
d | d d | d d | t | d t d
D d S ) Nc 4 g | ]}t | |S rW r4 )rs r) rW s r rt z)_TestMyManager.common.<locals>.<listcomp> ( OOOGC<N<NOtOOOr )r r r c 4 g | ]}t | |S rW r )rs r) bars r rt z)_TestMyManager.common.<locals>.<listcomp> r r r r r r r c g | ]}||z S rW rW r s r rt z)_TestMyManager.common.<locals>.<listcomp> s $<$<$<QQqS$<$<$<r r3 )
r r r rh r ri rB r r r+ r r rP )rm r r foo_methods bar_methodsr rW s @@r r z_TestMyManager.common s kkmmkkmmkkmmOOOO(8OOO OOOO(8OOO sCj111 sDk222 %((( *ce,,, --u555 +s=== %((( 6*** --u555 ..777 c$<$<%))$<$<$<=====r N)rr rs rt r r r r r rW r r r r s[ M G G GG G G7 7 7> > > > >r r c t S r )_queuerW r r get_queuer s Mr c e Zd ZdZdS ) QueueManagerz$manager class used by server processNrr rs rt ru rW r r r r s ....r r r c e Zd ZdZdS )
QueueManager2z@manager class which specifies the same interface as QueueManagerNr rW r r r r s JJJJr r xmlrpclibc J e Zd ZdZg dZedd Zed Zd ZdS )_TestRemoteManagerr ) hello worldNT @u hallå världenu привіт світs
hall vrldenNc t ||t t }| | }| t
| j d S )Naddressr
serializerr )r
SERIALIZERr connectr r r rN r r r r r s r _putterz_TestRemoteManager._putter se W -/ / / !!##
%
##$$$$$r c t j d }t t j df|t
t }| | |j |
| j |j |f }d|_
| t |j |t
t }| | }| | | j | t* |j t. j ~d S )N r r r T)r? urandomr r HOSTr r r r_ r r r r r r r r rh r rV ri re r r r )rm r r r manager2r s r test_remotez _TestRemoteManager.test_remote
s *R.. "'+W -/ / /
())) LL GOW3ML N N OW -/ / / ""$$ dk222
)UY
;;;
EEr ) rr rs rt r rN rV r r r rW r r r r sa M F
AAAYF% % [% r r md5c * e Zd Zed Zd ZdS )_TestManagerRestartc t ||t t }| | }| d d S )Nr r )r r r r r r r s r r z_TestManagerRestart._putter- s[ W -/ / / !!##
- r c v t j d }t t j df|t
t } | }|j }|j
| | | j
|j |f }| | | }| | d ~t% |d r| n*# t% |d r| w w xY wt ||t
t } | | |j d S # t* $ r}|j t, j k r t1 j d t ||t
t }t% |d r | |j Y d }~d S Y d }~d S d }~ww xY w)Nr r r r r r r- )r? r r r r r r
get_serverr listenerr r r r r r rh r r4 r r_ OSErrorerrno
EADDRINUSEr r )rm r r srvraddrr r r s r test_rapid_restartz&_TestManagerRestart.test_rapid_restart6 s? *R.. "'+W!4DF F F #%%''D<D
M ! ! ! MMOOO DL7Q RRA
GGIII
FFHHH%%''E UYY[[- 8 8 8w
++
# """ w
++
# """"
# 'j -/ / /
2 MMOOO OOG , - - - - -
2
2
2w%***
JsOOO" g*!13 3 3G w
++
2 0111111111
2
2
2
2
2
2
2s% CD4 4'E<.F, ,
H86A1H33H8N)rr rs rt r r r rW r r r r * s> ! ! [!'2 '2 '2 '2 '2r r c e Zd ZdZed Zd Zd Zd Zd Z ed Z
edd Z e j
ed
d Z e j
ed
e j ej d k d
e j edk d e j
eed d d Zed Z e j
ed
e j ej d k d d Zd ZdS )_TestConnectionr c t |j t D ]}| | | d S r )r
recv_bytesSENTINEL
send_bytesr )r r8 msgs r _echoz_TestConnection._echoi sC 22 ! !C OOC
r c | \ }}| | j |f }d|_ | g d}t d }|dz }t
j dt t d }| j dk r:|
t | t |
| | d |
| | |
| | d |
| | | j dk rNt
j dd gdz }t | d gdt% | z
z z } |
| | d |
| | t% | |j z |
t | | t
j dd gdz }d gd
z t | z d gd t% | z
z z } |
| | d |
| |d
|j z t% | |j z |
t | | t+ t d }|
| | d | | }
| d
|
z n8# t. j $ r&} |
| j |f Y d } ~ nd } ~ ww xY wt5 |j } |
| d | | j d |
| d d | | j d |
| t< d | | j t< | d t? j d |
| t< d | | j d |
| d t d dz }
| |
|
| |
| tB |" | j dk rv|
|j# d |
|j$ d | % tL |j | % tL |j |' d S )Nr T)r r Nr r3 rS r^ r r r r
z( z expected BufferTooShort, got %sFr> r Xi )(r r r r r r rv r rP r rh r filenorF r r r r r recv_bytes_intoitemsize bytearrayrf r BufferTooShortrN rz r r r} r r r r r readablewritableri EOFErrorr )rm r8 r r rp r longmsgrw bufferrW r r r really_big_msgs r test_connectionz _TestConnection.test_connectiono sl 99;;j LL
* L ? ? ooM""(k#tE!HH~~.. 9 # # T$++-- 0 0# 6 6 6 3 ... c*** --t444 **C000 9 # #[qc"f--FCyyA3"s3xx-#88H T__S 1 14 8 8 8 T 1 1& 9 9 XX 7
9
9
9 T&\\8 4 4 4[qc"f--FsQwc*aSFSXX4E-FFH T__S 1 14 8 8 8 T 1 1&!fo:M N N XX 7
9
9
9 T&\\8 4 4 4 uX//F T__W 5 5t < < <
C**622 ;cABBBB #1
5
5
5 '44444444
5
TY'' ''' $$T\1555 b5))) $$T\1555 h /// $$T\8<<< $
2 h ... $$T\1555 d+++ s'78 ''' **N;;; !!! 9 # # T]D 1 1 1 T]D 1 1 1 h 2 2 2 h 8 8 8 s 2N O/ OOc | d \ }}| | d d | | d | j dk r| |j d | |j d | |j d | |j d | t |j d | t |j | t |j d S d S )NFr r r Tr )
r rh r r r r r ri r r )rm readerwriters r test_duplex_falsez!_TestConnection.test_duplex_false s %00 Q ... *** 9 # # V_d 3 3 3 V_e 4 4 4 V_e 4 4 4 V_d 3 3 3 gv{A 6 6 6 gv{ 3 3 3 gv{ 3 3 3 3 3 $ #r c | \ }}| | j |f }d|_ | | t
d }| | | | | | t | | d S )Nr Tr ) r r r r r r r r rh r r r )rm r8 r r r s r test_spawn_closez _TestConnection.test_spawn_close s 99;;j LL
* L ? ? Gnn **C000 !!!
r c | j dk r-| d | j t d }| \ }}| | | | | | |d | | |dd | |dd | | |dd | |d | | t d | |dd
| | t d | t |j |d | t |j |d d | t |j |dd
| t |j |d | t |j |dd d S )Nr r abcdefghijklmnopqrstuvwxyzr r
r r r r r> r^ )
r r r r r r rh r ri rB )rm r r r s r test_sendbytesz _TestConnection.test_sendbytes s 9 # # MM7>>tyII J J J011yy{{1 S --- S! QRR111 S!Q QsU444 S" r333 S"a r333 *alC<<< *alCQ??? *alCQ??? *alC<<< *alCB?????r c t j | dS # t $ r!}|j t j k rY d }~dS d }~ww xY wr] )r? fstatr r EBADF)r r r s r _is_fd_assignedz _TestConnection._is_fd_assigned
s[ HRLLL 4 w%+%% uuuuu s
A>>AFc n |rOt dd D ]>}| | s't j | | ?t j | }t r t j |t j }t j
|| t j | d S )Nr r6 ) rP r r? dup2r r
recv_handlemsvcrtopen_osfhandler r0 r )r r8 datacreate_dummy_fdsrS r s r _writefdz_TestConnection._writefd
s .1c]]
.
.**1-- .GDKKMM1---
"4
(
( 8&r2;77B
T
r $test needs multiprocessing.reductionc | j dk r| d | d \ }}| | j |df }d|_ | | t j t j
t t j
d 5 }| }t rt j | }t j |||j d d d n # 1 swxY w Y | t t j
d 5 }| | d d d d d S # 1 swxY w Y d S ) Nr only makes sense with processesTr s foor wbrb)r r r r r# r r r_ r r r r r r
get_osfhandler
send_handler r rh r )rm r8 r r r r s r test_fd_transferz _TestConnection.test_fd_transfer
s 9 # # MM; < < < 99D911j LL
Z4HL I I ()*:;;;
)"D
)
) 3QB
.)"-- !$AE 2 2 2 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3
)"D
)
) /Q QVVXXv . . . / / / / / / / / / / / / / / / / / /s% 7A DDD)E==FFr- *test semantics don't make sense on Windowsr6 z)largest assignable fd number is too smallr ztest needs os.dup2()c | j dk r| d | d \ }}| | j |ddf }d|_ | | t j t j
t t j
d 5 }| }t dt D ]}| | s n| d t# j || t' j |||j t# j | n# t# j | w xY w d d d n # 1 swxY w Y | t t j
d
5 }| | d d d d d S # 1 swxY w Y d S ) Nr r& Tr s barr r' r6 z2could not find an unassigned large file descriptorr( )r r r r r# r r r_ r r r r r rP MAXFDr rf r? r r
r* r r r rh r )rm r8 r r r r newfds r test_large_fd_transferz&_TestConnection.test_large_fd_transfer*
s< 9 # # MM; < < < 99D911j LL
Z4NL O O ()*:;;;
)"D
)
) QB sE**
P
P++E22 E NOOO GB
%dE15999
)"D
)
) /Q QVVXXv . . . / / / / / / / / / / / / / / / / / /s= 8A.E='EE=E--E==FF6)G,,G03G0c T t j | d d S )N )r? r0 r rm r8 s r _send_data_without_fdz%_TestConnection._send_data_without_fdK
s"
&&&&&r z doesn't make sense on Windowsc \ | j dk r| d | d \ }}| | j |f }d|_ | | t t j
| | d S )Nr r& Tr r ) r r r r r4 r r ri r1 r
r r rm r8 r r s r test_missing_fd_transferz(_TestConnection.test_missing_fd_transferO
s
9 # # MM; < < < 99D911j LL :* L O O , (=tDDD r c | \ }}|5 |5 | d | | d | j dk r4| |j | |j d d d n # 1 swxY w Y d d d n # 1 swxY w Y | j dk rv| |j | |j | t |j | t |j d S d S N r )
r r rh r r r closedr ri r r s r r7 z _TestConnection.test_context^
s yy{{1
+ + + +
FF4LLL QVVXXt , , ,yK'' *** *** + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 9 # # OOAH % % % OOAH % % % gqv . . . gqv . . . . . $ #s5 B=A=B& B=&B* *B=-B* .B==CCNr )rr rs rt r r r r
r r r r r# rC r
HAS_REDUCTIONr+ rv rw rx r. r4 r? r0 r4 r7 r7 rW r r r r e s ,M [
M M M^ 4 4 4 * @ @ @@ [ [ X (NOO/ / PO/$ X (NOOX_S\W,AC CX_Uc\@B BXV,,/1 1/ /1 1B BC C PO/4 ' ' [' X (NOOX_S\W,.MNN ON PO / / / / /r r c \ e Zd ZdZd Zd Z ej ej d d Z
dS )
_TestListenerr c | j j D ]c}| j | }| |j | t | j j |j | dd S )Nfamily)
connectionfamiliesListenerr_ r ri r r )rm rA r s r test_multiple_bindz _TestListener.test_multiple_bindr
sy o. 1 1F(((77A OOAG $ $ $ gt'? i
1
1
1
1 1 1r c | j 5 }| j |j 5 }| 5 }| d | | d d d d n # 1 swxY w Y d d d n # 1 swxY w Y d d d n # 1 swxY w Y | j dk r"| t |j d S d S r9 rB rD Clientr acceptr rh r r ri r )rm r r r@ s r r7 z_TestListener.test_contexty
s
_
%
%
'
' 51 '' 22
5aXXZZ 51FF4LLL$$QVVXXt4445 5 5 5 5 5 5 5 5 5 5 5 5 5 5
5
5
5
5
5
5
5
5
5
5
5
5
5
5
5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 9 # # gqx 0 0 0 0 0 $ #sX CB0>B
B0B B0 B !B0$ C0B4 4C7B4 8CC C z"test needs abstract socket supportc | j d 5 }| j |j 5 }| 5 }| d | | d d d d n # 1 swxY w Y d d d n # 1 swxY w Y d d d n # 1 swxY w Y | j dk r"| t |j d S d S )Nz
somethingr: r rG )rm r clientr@ s r test_abstract_socketz"_TestListener.test_abstract_socket
s _
%
%m
4
4 5 ''(899
5V __&& 5!KK%%%$$QVVXXt4445 5 5 5 5 5 5 5 5 5 5 5 5 5 5
5
5
5
5
5
5
5
5
5
5
5
5
5
5
5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 9 # # gx 7 7 7 7 7 $ #sX CB1>B B1B B1!B "B1% C1B5 5C8B5 9CC C N) rr rs rt r rE r7 rC r r abstract_sockets_supportedrL rW r r r> r> n
sl "M1 1 11 1 1 X8=? ?8 8? ?8 8 8r r> c : e Zd ZdZed Zd Zd Zd ZdS )_TestListenerClientr c | j | }| d | d S )Nr )rB rH r r )r r r8 s r r z_TestListenerClient._test
s: ~$$W-- '
r c | j j D ]}| j | }| | j |j f }d|_ | | }| |
d | | d S )Nr@ r Tr )
rB rC rD r r r r r rI rh r r r )rm rA r r r8 s r test_listener_clientz(_TestListenerClient.test_listener_client
s o. F(((77A DJai\ BBAAH
GGIII88::D TYY[[' 2 2 2
FFHHH
GGIIII r c | j }| | j |j f }d|_ | t j d | }|
| d | |
| d S )Nr Tr r )rB rD r r r r r r r rI rh r r r )rm r r r8 s r test_issue14725z#_TestListenerClient.test_issue14725
s O $ $ & & LL
!) L > >
1
xxzz g...
r c | j j D ]}| j | }| j |j }| }| d | | d | | | d S )Nr@ hellor )
rB rC rD rH r rI r r r r )rm famr r r s r test_issue16955z#_TestListenerClient.test_issue16955
s ?+ C(((44A&&qy11A
A
LL " " " OOAFF1II & & &
GGIII
GGIII
GGIIII r N) rr rs rt r r r rR rT rX rW r r rO rO
s_ ,M [
r rO c l e Zd ZdZd Zed Zd Zed Zd Z ed Z
d Z d S )
_TestPollr c N | \ }}| | d | d | | d | | d d S )NFr T)r rh r r r s r test_empty_stringz_TestPoll.test_empty_string
s yy{{1 5))) S 4((( 4(((((r c |D ]+}t j d | | ,| d S Nr )r r r r )r r8 stringsr s r _child_stringsz_TestPoll._child_strings
sD A JsOOO OOA
r c t d}| \ }}| | j ||f }| |D ]U}t d D ]}| d r n| }| || V| d S )N)rV r a br s byer s lopr rq ) r r r` r rP r r rh r )rm r_ r r r r rS rE s r test_stringsz_TestPoll.test_strings
s Gyy{{1 LL 31g,L G G # #A3ZZ
66$<< E A Q " " " " r c 0 | d d S r )r )r r6 s r _child_boundariesz_TestPoll._child_boundaries
s
q r c | d \ }}| | j |f }| t j d ddg}|D ]}| | | | | |
| d S )NFr r s firsts second) r r rg r r r r r r rj r )rm r6 r r r5 r& s r test_boundariesz_TestPoll.test_boundaries
s yy 1 LL 6aTL B B
1
y ! C
LL
allnna(((((r c | d | d | d d S )Nrb rc cd)r )r r s r _child_dont_mergez_TestPoll._child_dont_merge
s> T T Ur c | \ }}| | d d | | d d | | j |f }| | | d | | d d | | d d | | d | | d d | | d d | | d d | | d | d S )
Nr1 Fr r rb r- Trc rk )r rh r r rl r r r )rm r r r s r test_dont_mergez_TestPoll.test_dont_merge
s yy{{1 e,,, e,,, LL 6aTL B B ... d+++ d+++ ... d+++ d+++ d+++ /// r N) rr rs rt r r\ r r` re rg ri rl rn rW r r rZ rZ
s ,M) ) ) [
[
)
)
) [
r rZ r$ c v e Zd ZdZed Zed Zed Zd Zed Z d Z
dS ) _TestPicklingConnectionsr c R ddl m} | t j d S )Nr )resource_sharerr )r rr r r r )r rr s r r z&_TestPicklingConnections.tearDownClass s4 333333 W%9 :::::r c z |D ]}| j | }| |j | }| | | | t
j t j df }| |
| \ }}| | | | | d S )Nr@ r ) rB rD r r rI r socket
create_serverr r getsocknamer )r r8 rC rW r new_connr s r _listenerz"_TestPicklingConnections._listener s C''s'33A IIai xxzzH IIh NN
GGIIII -"4a!8 9 9 !--//"""$ ( r c t |j d D ]Z\ }}| j | }| | | [| \ }}t j }| | | | | | d S r )
r r rB rH r r r rt r sendall)r r8 r r rK s r _remotez _TestPicklingConnections._remote0 s "49d 3 3 NWc^**733F KK $ $ $ LLNNNNyy{{ w syy{{###
r c l | j j }| \ }}| | j ||f }d|_ | | | \ }}| | j |f }d|_ | | |D ]}d|z d } |
}
| |
| f |
} | |
|
| d t d } |
}
| |
| f |
} g } |
d }
|
sn| |
.d | } | | |
| | d | | | | d S )Nr Tz This connection uses family %sasciiz$This connection uses a normal socketr& r )rB rC r r rx r r r r{ r r r rh r r rU r )rm rC lconnlconn0lpr rconn0rprW r r rw bufr s r
test_picklingz&_TestPicklingConnections.test_pickling? s8 ?+
v
\\ vx6H\
I
I
v
\\ VI\
>
>
; ;C3c9AA'JJCjjllG JJ~ & & & zz||H X]]__ciikk : : : :
4:;;**,,
GS>"""::<<
c""A
JJqMMM
hhsmm ciikk***
4
r c ( | }| d | | }| }| |dz | d S )N all is wellr )r r r )r r8 r r6 r s r child_accessz%_TestPicklingConnections.child_accessm so IIKK } IIKKffhh #a%
r c | \ }}| | j |f }d|_ | | | d \ }}| | | | | d | | d \ }}| | | | d | | | d | d S )Nr TFr r foobar foobarfoobar)
r r r r r r r rh r r )rm r8 r r r6 r s r test_accessz$_TestPicklingConnections.test_accessy s5 99;;j LL 1
L F F yyy&&1 ! =111 yyy&&1 ! x j111 r N) rr rs rt r r r rx r{ r r r rW r r rp rp s #M; ; [; [$ [ , , ,\ [ r rp c 8 e Zd ZdZ fdZ fdZd Zd Z xZS ) _TestHeapr c t t j j j | _ t j t j j _ d S r )r r r r r _heapold_heapHeaprm r s r r z_TestHeap.setUp sG
',:@
3B3G3L3L3N3N *000r c ~ | j t j j _ t d S r )r r r r r r r r s r r z_TestHeap.tearDown s/ 37= *0
r c
, d}d}g }t j j j }d|_ t | D ]}t
t j dd dz }t j | }| | t | |k rt j | }||= ~|j 5 g }d} d}
t |j D ]H} | D ]C\ } }
}| |j | |
|||
z
df | ||
z
z
} DI|j D ]J\ } }|D ]B\ }
}| |j | |
|||
z
df |
||
z
z
}
CK| | |
z t+ d |j D | t t | dz
D ]}|| d d \ } }
}||dz d d \ }}}| |k r=| ||j | j | |d p| || d d d n # 1 swxY w Y t j | |r| || |j |j | t |j d | t |j d | t |j d|j | t |j d d S )
N r r r r; freeoccupiedc 3 $ K | ] }|j V d S r rz )rs arenas r r z&_TestHeap.test_heap.<locals>.<genexpr> s$ F F F F F F F Fr r ) r r r r _DISCARD_FREE_SPACE_LARGER_THANrP rF randomlognormvariaterU r randranger r _len_to_seqrN _arenasindex_allocated_blocksr rh sumsortrz shuffler _n_frees
_n_mallocs_pending_free_blocks)rm
iterations maxblocksblocksr rS rz r r r r r5 r r r arena_blocksnarenanstartnstops r test_heapz_TestHeap.test_heap s
#17/0, z"" Av,Q22T9::D $22488A MM! 6{{Y&&$Y//1I Z 3 3CDH$*113344
)
)*+ ) )&E5$JJ 2 25 9 95$ $U
F 4 5 5 5T%Z(DD) (,'='C'C'E'E
-
-#|#/ - -KE4JJ 2 25 9 95$ $U
J 8 9 9 9 e,HH-
TH_ F F F F F F F
H
H
H
HHJJJ3s88A:&&
3
3'*1vbqbz$t*-ac(2A2,'F??$$T4<+>+CDDD$$VQ//// $$T62222
3- 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3D v JJLLL
888 T 677;;; T\**A... T 344a9OPPP T -..22222s G JJ Jc t j s2t j | t j t j } | j t j g|R t j d t d D ]N}t j
d }t j
d }||_ ||_ Od S )Nr3 r r ) ri isenabledenabler_ disable
get_threshold
set_thresholdrP r r r buddy)rm
thresholdsrS r r s r test_free_from_gcz_TestHeap.test_free_from_gc s |~~ ( IKKK OOBJ ' ' '%''
(6:6666
t A $22155A $22155AAGAGG r ) rr rs rt r r r r r r` ra s @r r r sz "MO O O O O >3 >3 >3@ r r c $ e Zd ZdefdefdefgZdS )_FoorE rF zN)rr rs rt r9 r: r; _fields_rW r r r r s+ e h j
HHHr r c B e Zd ZdZd Zed Zd dZd Zd Z dS )
_TestSharedCTypesr c B t s| d d S d S rH rI r s r r z_TestSharedCTypes.setUp
rJ r c $ |xj dz c_ |xj dz c_ |xj dz c_ |xj dz c_ |xj dz c_ |xj dz c_ t t | D ]}||xx dz cc< d S ru )r rE rF rP r )r rE rF r rW rw stringrS s r _doublez_TestSharedCTypes._double s 1 1 1
s3xx A FFFaKFFFF r Fc t dd| }t t d| }t t d| }t t dd| }| dt t
d | }| d
d | }t d |_ | | j
||||||f
}d|_ | |
| |j d | |j d | |j d | |j d | |j d t
d D ]!} | || | dz "| |j t d d S )NrS r
r] gUUUUUU?rC r r r@ r3 r r r r T gUUUUUU?rD r @
hellohello)r r: r; r ru r rP r r r r r r r rh r rE rF )
rm rc rE rF r rW rw r r rS s
r test_sharedctypesz#_TestSharedCTypes.test_sharedctypes s #qt $ $ $ (G$ / / / *gD 1 1 1D!QT***jjd599ooDj99C$// W~~ LL Aq!S#v3NL O O "%%% qw000 '*** """ suc***r 0 0A " "3q61Q3 / / / / u\':':;;;;;r c 2 | d d S )NTr] )r r s r test_synchronizez"_TestSharedCTypes.test_synchronize3 s D )))))r c t ddd }t | }d|_ d|_ d|_ | |j d | |j d | |j d d S )Nr @rC r )r r rE rF r rh r )rm rW r s r test_copyz_TestSharedCTypes.test_copy6 s 1c7##3ii """ suc*** (((((r Nr )
rr rs rt r r r r r r r rW r r r r sx "MC C C [< < < <.* * *) ) ) ) )r r z&requires multiprocessing.shared_memoryc e Zd ZdZed Zd Zd Zd Zd Z d Z
d Z d Z e
j ej d
k d d Z e
j ej d
k d
d Zd Zd Zd Zd Zd ZdS )_TestSharedMemoryr c t | t rt j | }n| }||j d t | < | d S r )r rk r SharedMemoryr r r )shmem_name_or_obj binary_data local_smss r !_attach_existing_shmem_then_writez3_TestSharedMemory._attach_existing_shmem_then_writeG s] ' - - *%23DEEII)I+6
's;'''(r c H |t t j z S r )rk r? r )rm prefixs r
_new_shm_namez _TestSharedMemory._new_shm_nameP s BIKK((((r c X | d }t j |dd }| |j | |j | | |j d | t |j
|j | |j t | | t |j t | d|j
d< | |j
d d t j | }| |j
d d |
t j |d|j z }| |j d|j z |
| t 5 t j dd d d d n # 1 swxY w Y | t 5 t j d
d d d n # 1 swxY w Y t" j d 5 }t j | d
| d g}fd|D }||_ t j dd }| |j | |j |d ||_ t j dd }| |j | |j |d d d d n # 1 swxY w Y t j r| d } t j | dd }
| t0 5 | |
j d t j | } | |
|
|
n# |
w xY w d d d n # 1 swxY w Y | t2 5 t j |dd } d d d n # 1 swxY w Y t j rW G d dt j }
|
| }| |j |j |
| t0 5 t j d }| d d d n # 1 swxY w Y |
d S )N test01_tsmbT createrz rh r r r Fr ,multiprocessing.shared_memory._make_filename test01_fn test02_fnc g | ]}|z S rW rW rs r) NAME_PREFIXs r rt z?_TestSharedMemory.test_shared_memory_basics.<locals>.<listcomp> :::D[4':::r r test01_dblunlinkr c , e Zd Zej ej z ZdS )O_TestSharedMemory.test_shared_memory_basics.<locals>.OptionalAttachSharedMemoryN)rr rs rt r? r O_RDWR_flagsrW r r OptionalAttachSharedMemoryr s bi/r r test01_notthere)r r r r_ r rh r) r7 rz r r rj rk r
assertLessri rB rC mockpatch_SHM_NAME_PREFIX side_effect_name
_USE_POSIXFileNotFoundErrorFileExistsError)rm name_tsmbsmsalso_smssame_smsmock_make_filenamenamesshm1shm2name_dblunlinksms_unosms_duothere_can_only_be_one_smsr ok_if_exists_smsnonexisting_smsr s @r test_shared_memory_basicsz+_TestSharedMemory.test_shared_memory_basicsV s &&}55 (4cJJJ
###
9--- #... CG ch777
chC)))
c#(mmSXX...
R((( !-i88 a "--- !-ibkJJJ
r#({333
z
*
* = = &d < < < < = = = = = = = = = = = = = = =
z
*
* 5 5 &e 4 4 4 4 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5
]
:< < 3?Q'8K'' 44d6H6H6U6UVE ;:::E:::E-2 * -TBBBD OODK ( ( ( TZq 2 2 2-2 * -TBBBD OODK ( ( ( TZq 2 2 2# 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3& # % " / /0B C CN#0 G
""#455
%
% %++GL$??? + 8 H HGNN$$$MMOOOMMOOO NN$$$$GNN$$$$$
%
%
%
%
%
%
%
%
%
%
%
%
%
%
%
/
/ )6(B) ) ) % # %
0
0
0
0
0]-G
0
0
0 9 9) D D - 2CH = = = " " $ $ $
0
1
1 % % + 89J K KO " " $ $ $ % % % % % % % % % % % % % % % s +HHH3II I?C5N NN R A+Q
R Q55RR R *SSS)V VVc ` t j d 5 }t j | d | d g}fd|D }||_ t j dd }| |j |
|j |d ||_ t j dd }| |j |
|j |d d d d d S # 1 swxY w Y d S ) Nr test03_fn test04_fnc g | ]}|z S rW rW r s r rt zA_TestSharedMemory.test_shared_memory_recreate.<locals>.<listcomp> r r Tr r r ) rC r r r r r r r r_ r rh r )rm r r r r r s @r test_shared_memory_recreatez-_TestSharedMemory.test_shared_memory_recreate sg ]
:< < 3?Q'8K'' 44d6H6H6U6UVE ;:::E:::E-2 * -TBBBD OODK ( ( ( TZq 2 2 2-2 * -TBBBD OODK ( ( ( TZq 2 2 2# 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s C5D##D'*D'c | t 5 t j dd }d d d n # 1 swxY w Y | t 5 t j dd }d d d n # 1 swxY w Y | t 5 t j d }d d d d S # 1 swxY w Y d S )NTr> r r r )ri rB r r )rm sms_invalids r "test_invalid_shared_memory_crationz4_TestSharedMemory.test_invalid_shared_memory_cration s
z
*
* K K'4DrJJJK K K K K K K K K K K K K K K K
z
*
* J J'4DqIIIK J J J J J J J J J J J J J J J
z
*
* B B'4DAAAK B B B B B B B B B B B B B B B B B Bs3 >AA#BB
B
+CCCc ` t t j dz D ]}| | 5 t j dd }| |j d|j dd< t j || }t j
| }| |t j | |j
|j
| t |j dd d | t |j dd d d
|j dd< | t |j dd d
| t |j dd d
d |j dd< | t |j dd d | t |j dd d d d d n # 1 swxY w Y d S ) Nr protoTr r pickler r protocols newvals oldval)rP pickleHIGHEST_PROTOCOLr r r r_ r r dumpsloadsr rh r) r )rm r r pickled_smssms2s r "test_shared_memory_pickle_unpicklez4_TestSharedMemory.test_shared_memory_pickle_unpickle sL 62Q677 B BE E **
B
B#03GGG
+++ (! %l3 ? ? ? |K00%%dM,FGGG 49555 swqs|!4!4i@@@ tx!}!5!5yAAA )! swqs|!4!4i@@@ tx!}!5!5yAAA )1
swqs|!4!4i@@@ tx!}!5!5yAAA-
B
B
B
B
B
B
B
B
B
B
B
B
B
B
B B Bs G H!!H% (H% c t t j dz D ]}| | 5 t j dd }d|j dd< t j || }| | |
t 5 t j | d d d n # 1 swxY w Y d d d n # 1 swxY w Y d S )
Nr r Tr r r r r r )
rP r r r r r r r r r ri r r )rm r r r s r .test_shared_memory_pickle_unpickle_dead_objectz@_TestSharedMemory.test_shared_memory_pickle_unpickle_dead_object sc 62Q677 . .E E **
.
.#03GGG (! $l3 ? ? ?
&&'899 . .L---. . . . . . . . . . . . . . .
.
.
.
.
.
.
.
.
.
.
.
.
.
.
. . .s6 A;C(0C C(C C(C C((C, /C, c t j dd }| |j | | j |j df }d|_ | | |
t |j d d d | | j |df }d|_ | | |
t |j d d d |
d S )NTr r s howdyr r s HELLO)r r r_ r r r r) r r r rh r r r )rm r r s r #test_shared_memory_across_processesz5_TestSharedMemory.test_shared_memory_across_processes s% (3???
###
LL9(H%
swrr{++X666
LL9x
swrr{++X666 r r% z#not feasible in non-posix platformsc 0 t j }| | t d }t
j |j j t j | t d }| t 5 t
j t
j t j d d d n # 1 swxY w Y | d S r )r managersSharedMemoryManagerr
ShareableListrP r? rA r r r5 r ri r r r )rm smmslsl2s r 4test_shared_memory_SharedMemoryServer_ignores_sigintzF_TestSharedMemory.test_shared_memory_SharedMemoryServer_ignores_sigint. s
&::<<
uRyy
)
)
&-000 b **
0
1
1 0 0 GBIKK / / / 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 s :1C77C;>C;z resource_tracker is posix onlyc d}t j j d| \ }}}| | d S )Nzif 1:
from multiprocessing.managers import SharedMemoryManager
smm = SharedMemoryManager()
smm.start()
sl = smm.ShareableList(range(10))
smm.shutdown()
r )rA r r r r r s r >test_shared_memory_SharedMemoryManager_reuses_resource_trackerzP_TestSharedMemory.test_shared_memory_SharedMemoryManager_reuses_resource_trackerF sG |1BB4MM C
r c t j | t 5 d d d d n # 1 swxY w Y fdt dd D } fdt ddd D }t j |d
j
j }| t | d t j |d
j }| t |j d |d
j } t" j d k rG| t& 5 t j | }d d d n # 1 swxY w Y t j 5 }| d
}| d } |j
j }d d d n # 1 swxY w Y t" j d k rJ| t& 5 t j | }
d d d d S # 1 swxY w Y d S d S )Nr r c T g | ]$} t | %S rW )r" rP )rs rS smm1s r rt zS_TestSharedMemory.test_shared_memory_SharedMemoryManager_basics.<locals>.<listcomp>` s- DDD""588,,DDDr r r3 c < g | ]} | S )r )r )rs r< r+ s r rt zS_TestSharedMemory.test_shared_memory_SharedMemoryManager_basics.<locals>.<listcomp>a s* GGGa!!q!))GGGr r r r) r- howdy)r r r! ri rB r r rP r r" shmr) rh r r7 r r rw rx r ) rm lollomdoppleganger_list0doppleganger_shm0 held_name
absent_shmsmm2r$ r1 absent_slr+ s @r -test_shared_memory_SharedMemoryManager_basicsz?_TestSharedMemory.test_shared_memory_SharedMemoryManager_basics[ sh ';;==
z
*
* & & 1 % % % & & & & & & & & & & & & & & &
DDDDeArllDDDGGGG5S"3E3EGGG * 8c!fjo N N N /00!444 ) 6CFK H H H $5$9 : :B???FK
<7 " " ""#455
H
H * 7Y G G G
H
H
H
H
H
H
H
H
H
H
H
H
H
H
H
%
9
9
;
; $t##G,,B###--C I $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ <7 " """#455
H
H ) 7Y G G G
H
H
H
H
H
H
H
H
H
H
H
H
H
H
H
H
H
H # "sG A A!$A!F22F69F68H H#&H#I77I;>I;c t j g d }| |j j | |j j t | | t t | t | | t 5 |d d d d n # 1 swxY w Y | t 5 d|d< d d d n # 1 swxY w Y | d }d|d< | || d | |j
d | t | d t j 5 t j d | t$ 5 | d d d d n # 1 swxY w Y | | d d
d d d n # 1 swxY w Y | |d d | |d d | t) | d d
|d
< | |d
d
d|d< | |d d | |j
d | t$ d 5 d|d< d d d n # 1 swxY w Y | |d d d|d< | |d d | |d d | t$ d 5 d|d< d d d n # 1 swxY w Y | |d d | t$ d 5 d|d< d d d n # 1 swxY w Y | |d d t j 5 t j d | | d
d | | d d | | d d d d d n # 1 swxY w Y | d }t j || } | |j j |j j | ||j j | t | t | | |j
|j
d|d < | |d d | |d d |j |j n # |j w xY wt j |j j }| |j j |j j d |d < | |d d |j |j t j } | t | d | |j
d | | d d | t$ 5 | d d d d n # 1 swxY w Y |j |j d S # |j w xY w) N)r0 HoWdYgX9vqr& NTrh r
r r r0 z8s8sdqxxxxxx?xxxxxxxx?qignore100r& r r Trh somer^ z8s8sdq8sxxxxxxx?qzexceeds available storagez far too manyu encodésr r< u encodéess 123456789s adiostest03_duplicater/ M r> ip r any)r r" r_ r1 r rj r) rk r ri
IndexError_get_packing_formatrh r r warningscatch_warnings simplefilterrB r r rX r r r r )rm r$ current_formatname_duplicatesl_copy sl_tetheredempty_sls r 'test_shared_memory_ShareableList_basicsz9_TestSharedMemory.test_shared_memory_ShareableList_basicsy s[
( > > >
&&&
bfk3r77+++
c$r((mmSWW---
z
*
* qEE
z
*
* BqE //221 )?)?)B)BCCC
$=>>>
R!$$$
$
&
& / / !( + + +"":..
RXXc]]A . . . / / / / / / / / / / / / / / /
A((( B&&&
"II >
1 A###1 A''' $7888
#
#J$?A A # #"BqE # # # # # # # # # # # # # # #
A'''1 A
+++ A)))
#
#J$?A A BqE
A)))
#
#J$?A A ! ! BqE ! ! ! ! ! ! ! ! ! ! ! ! ! ! !
A)))
$
&
& 4 4 !( + + + RXXb\\1 - - - RXXh / / 3 3 3 RXXh / / 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 ++,>?? -b~FFF
! W[-= > > > ^W[-= > > > T"XXtG}} 5 5 5 RY 7 7 7 GBK WR[" - - - 2 + + + K K GK $1rv{CCC ko&:;;; B B%%%
!.00 " S]]A . . . X_b 1 1 1 X^^E 2 2A 6 6 6"":..
%
%t$$$
%
%
%
%
%
%
%
%
%
%
%
%
%
%
% L L ! ! ! ! !HL ! ! ! !s : CCC4DD
D
%/H6G6* H66G: :H6=G: >,H66H:=H:L&&L*-L*%N77N;>N;9P PPBS!!S%(S%C0X" "X=0B_ 1^ _ ^_ ^ _ _-c B t t j dz D ] }| | 5 t j t d }| |j j t j || }t j
| }| |t j | |d d |
|| d|d< | |d d d |d
< | |d
d t j t d }| |j j t j || }| t | t | |j |j |j d d d n # 1 swxY w Y d S ) Nr r r3 r r> r changedr^ newvaluer i )rP r r r r r" r_ r1 r r r r rh assertIsNotr r )rm r r$
serialized_sldeserialized_sl larger_slserialized_larger_sls r )test_shared_memory_ShareableList_picklingz;_TestSharedMemory.test_shared_memory_ShareableList_pickling s! 62Q677 E E **
"0r;;
... & R% @ @ @
"(,}"="=%%#]%@B B B !4a888 _555%." A 222"1 !3Z@@@ ) 7c
C C
4555'-|I'N'N'N$ ]!3!3S9M5N5NOOO
##%%% #))+++ /
s GHH H c t t j dz D ]}| | 5 t j t d }t j || }|j |j |
t 5 t j | d d d n # 1 swxY w Y d d d n # 1 swxY w Y d S )Nr r r3 r )
rP r r r r r" r r1 r r ri r r )rm r r$ rR s r 5test_shared_memory_ShareableList_pickling_dead_objectzG_TestSharedMemory.test_shared_memory_ShareableList_pickling_dead_object sY 62Q677 0 0E E **
0
0"0r;; & R% @ @ @
&&'899 0 0L ///0 0 0 0 0 0 0 0 0 0 0 0 0 0 0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0 0 0s6 BC19C C1C C1!C "C11C5 8C5 c d}t j t j dd|gt j t j 5 }|j }| |
d}t j t j
| D ]*} t j |d }# t $ r Y nw xY wt" j dk rYt' j d | d
|j }| d | d d d d S # 1 swxY w Y d S ) NaX if 1:
import os, time, sys
from multiprocessing import shared_memory
# Create a shared_memory segment, and send the segment name
sm = shared_memory.SharedMemory(create=True, size=10)
sys.stdout.write(sm.name + '\n')
sys.stdout.flush()
time.sleep(100)
-Er r zIA SharedMemory segment was leaked after a process was abruptly terminatedFr r% /r z[resource_tracker: There appear to be 1 leaked shared_memory objects to clean up at shutdown)
subprocessPopenrw r PIPEr readlinestripdecoder r/ r sleeping_retryr r r r r? r) r&
unregisterr r rj )rm r r r) err_msgr r# rn s r 4test_shared_memory_cleaned_after_process_terminationzF_TestSharedMemory.test_shared_memory_cleaned_after_process_termination s
s~tT3 ?%/_%/_6 6 6 J9:8$$&&,,..5577D
KKMMM
FFHHH;G +G,@'JJ
'4T%HHHCC( EE w'!! !+JJJHHH
hmmoo,,..
DEHJ J J= J J J J J J J J J J J J J J J J J Js7 B E$C E$
C+'E$*C++A,E$$E(+E(N)rr rs rt r rQ r r r r
r
r r r rC rv r? r) r& r( r: rM rV rX re rW r r r r A sd #M \) ) ) n n n`3 3 3, B B BB B B4
.
.
. 8 X_RW')NOO PO. X_RW')IJJ KJ (H H H<o" o" o"b 6 0 0 0 +J +J +J +J +Jr r c l e Zd ZdZd Zd Zed Zd Z e j
d d Z dS )
_TestFinalizer c t j | _ t j d S r )r _finalizer_registryr registry_backupr r s r r z_TestFinalize.setUpH s4 # 7 < < > > &&(((((r c t j | t j t j | j d S r )ri rj r r ri updaterj r s r r z_TestFinalize.tearDownL sD
1222 ''(<=====r c G d dt } | }t j ||j d ~t j | }t j ||j d } | | ~t j | }t j ||j d | }t j ||j dd | }t j ||j d
d | } t j | |j d d | }
t j |
|j d
d t j d |j dd t j d |j dd t j | t j d d S )Nc e Zd ZdS ))_TestFinalize._test_finalize.<locals>.FooNr rW r r r ro S Dr r )r r )r )r )d10r )rN exitpriority)d01r )d02)d03)r i)STOPi)
r@ r Finalizer ri rj _exit_functionr r? _exit) r r8 r r r close_br rq rs rt ru s r _test_finalizez _TestFinalize._test_finalizeQ s &
CEE
a0000
CEE-496:::
CEE
a0000cee
c498!DDDDcee
c498!DDDDcee
c498!DDDDcee
c498!DDDD
dDIFEEEE
dDIIDIIII
r c : | \ }}| | j |f }d|_ | | d t
|j d D }| |g d d S )Nr Tc g | ]}|S rW rW )rs r& s r rt z/_TestFinalize.test_finalize.<locals>.<listcomp> s 999##999r rv )r r rq ru rt rs r ) r r r{ r r r r r rh )rm r8 r r rV s r
test_finalizez_TestFinalize.test_finalizey s 99;;j LL 3:-L H H 99di!8!8999 !L!L!LMMMMMr r c d G fddt d d fd} fd}t j }t j } t j d t j ddd t j | t j | g}t j
| 5 t j d
d d d d n # 1 swxY w Y t j | t j | t j
d S # t j | t j | t j
w xY w) Nc d S r rW rW r r cbz,_TestFinalize.test_thread_safety.<locals>.cb Dr c e Zd Z fdZdS )-_TestFinalize.test_thread_safety.<locals>.Fooc j | | _ t j | t j dd d S )Nr r& )rr )rh r rw r randint)rm r s r r~ z6_TestFinalize.test_thread_safety.<locals>.Foo.__init__ s3
dBV^As5K5KLLLLLLr N)rr rs rt r~ )r s r r r s5
M
M
M
M
M
M
Mr r Fc sZt j t j dz t j n# t
$ r } | Y d } ~ nd } ~ ww xY wXd S d S r^ )r r r r _run_finalizersre )r rA finishs r run_finalizersz8_TestFinalize.test_thread_safety.<locals>.run_finalizers s
6=??T1222 (**** CCCCCC
s A
A AAc i } sc fdt d D | t j d < n-# t $ r }|| Y d }~nd }~ww xY wad S d S )Nc $ h | ] }
S rW rW )rs rS r s r <setcomp>zL_TestFinalize.test_thread_safety.<locals>.make_finalizers.<locals>.<setcomp> s /I/I/I!/I/I/Ir r3 r )rP r getrandbitsre r )r@ r r rA r s r make_finalizersz9_TestFinalize.test_thread_safety.<locals>.make_finalizers s A
0J/I/I/IuRyy/I/I/IAf(++,, CGGIIIIIIII
s 08
A"A A"gư>r r r T)r@ rw getswitchintervalri r setswitchintervalr r r r
start_threadsr r rj )
rm r r old_interval
old_thresholdr r r rA r s
@@@@r test_thread_safetyz _TestFinalize.test_thread_safety s M M M M M M M& M M M
,.. (**
!$ ' ' ' Q1 % % % '~>>> '???AG!/88
3
!, / / / m , , JLLLLL
!, / / / m , , JLLLLs1 A(D' =C D' C$$D' 'C$(D' '7E N) rr rs rt r r r r r{ r~ r r r rW r r rg rg D s "M) ) )> > >
% % [%N N N N W u%%4 4 &%4 4 4r rg c e Zd Zd Zd ZdS )_TestImportStarc t dd l }t j t j }t j | | d }| | }d |D }d |D }| d | d |S )Nr z*.pyc g | ]J}t j t j | d d KS )r r )r? r splitextsplit)rs r s r rt z4_TestImportStar.get_module_names.<locals>.<listcomp> s@ KKK27##BGMM!$4$4Q$788;KKKr c g | ]}d |z S )zmultiprocessing.rW )rs r s r rt z4_TestImportStar.get_module_names.<locals>.<listcomp> s ;;;a%);;;r zmultiprocessing.__init__r )
globr? r dirnamer __file__r escaper rU )rm r folderpatternfilesmoduless r get_module_namesz _TestImportStar.get_module_names s !9::',,t{{6 2 2F;; '""KKUKKK;;7;;;1222()))r c b | }t j dk r@| d | d | d n1| d t s| d t
| d |D ]z}t
| t j | }| t |d | |j
D ]+}| t || |d| ,{d S ) Nr- zmultiprocessing.popen_forkz multiprocessing.popen_forkserverz!multiprocessing.popen_spawn_posixz!multiprocessing.popen_spawn_win32z multiprocessing.sharedctypes__all__z does not have attribute ) r rw rx r r< r9 r3 r r r4 r )rm r r) modattrs r test_importz_TestImportStar.test_import s@ '')) <7 " " NN7 8 8 8 NN= > > > NN> ? ? ? ? NN> ? ? ?
C ABBB = NN9 : : : D t +d#C OOGC 3 3T : : :
C&&7:ssDDA
r N)rr rs rt r r rW r r r r s2 r r c 4 e Zd ZdZd Zed Zd ZdS ) _TestLoggingr c t j }| t j | |d u | d | d | t d S )Nzthis will not be printedz
nor will this) r
get_loggersetLevelr
SUBWARNINGr debuginfo LOG_LEVEL)rm loggers r test_enable_loggingz _TestLogging.test_enable_logging sx +--((( d*+++ /000 O$$$ """""r c z t j }| | d S r )r r r getEffectiveLevel)r r8 r s r _test_levelz_TestLogging._test_level s4 +-- &**,,-----r c d}d}t j }t j }|j }t j d \ }}| | | | j |f }| |
|| | |
| t j | | | | j |f }| |
|| | |
| | | t d S )Nr % Fr r )level)r r logging getLoggerr r r r r r rh r r r NOTSETr ) rm LEVEL1LEVEL2r root_logger
root_levelr r
r s r
test_levelz_TestLogging.test_level sm +-- ')) &
(-U;;; LL 0yL A A /// ''' V$$$ LL 0yL A A /// Z(((i(((((r N)rr rs rt r r r r r rW r r r r sR "M# # # . . [.) ) ) ) )r r c p e Zd ZdZed Z ej ee d d d Z
dS )_TestPollEintrr c l t j d t j |t j d S r^ )r r r? rA r5 SIGUSR1)r r s r _killerz_TestPollEintr._killer4 s)
3
V^$$$$$r r requires SIGUSR1c dgfd}t j }t j t j | } | | j |f }| | t j d }| | | n# | w xY w|
d | |j d t j t j | d S # t j t j | w xY w)NFc dd< d S )NTr rW )rN
got_signals r recordz._TestPollEintr.test_poll_eintr.<locals>.record< s JqMMMr r )r r )
r? r r5 r r r r r r r r rh r )rm r r
oldhandlerkillerr r s @r test_poll_eintrz _TestPollEintr.test_poll_eintr9 s% W
! ! ! ! !ikk]6>6::
6\\ SF\CCF LLNNN
LL
L>>
OOJqM * * * QZ + + + M&.* 5 5 5 5 5FM&.* 5 5 5 5s$ 1D= /A C
8D=
C##9D= =!E N) rr rs rt r r r rC r r4 r5 r rW r r r r 0 sk "M% % [% X335GHH6 6 IH6 6 6r r c B e Zd Z ej ed d ZdS )TestInvalidHandleskipped on Windowsc * t j d } | n# t t
f$ r Y nw xY wd |_ n # d |_ w xY w| t t
ft j j d d S )NiMr> )r rB
Connectionr rB r _handleri r3 s r test_invalid_handlesz&TestInvalidHandle.test_invalid_handlesT s )44X>> IIKKKKG$ D
DLL4DL :w/)4? E E E E Es& 6 A A
A A
A A N)rr rs rt rC rv WIN32r rW r r r r R sB X_U 011 E E 21 E E Er r c e Zd Zd Zd ZdS ) OtherTestc G d dt }| t j t j j | d d S )Nc e Zd Zd Zd ZdS )FOtherTest.test_deliver_challenge_auth_failure.<locals>._FakeConnectionc dS )N something bogusrW rm rz s r r zQOtherTest.test_deliver_challenge_auth_failure.<locals>._FakeConnection.recv_bytesj s ))r c d S r rW rm r! s r r zQOtherTest.test_deliver_challenge_auth_failure.<locals>._FakeConnection.send_bytesl r N)rr rs rt r r rW r r _FakeConnectionr i s2
*
*
*
r r abc)r@ ri r AuthenticationErrorrB deliver_challengerm r s r #test_deliver_challenge_auth_failurez-OtherTest.test_deliver_challenge_auth_failureh sk f
/=)4F)/++V 5 5 5 5 5r c G d dt }| t j t j j | d d S )Nc e Zd Zd Zd Zd ZdS )EOtherTest.test_answer_challenge_auth_failure.<locals>._FakeConnectionc d| _ d S r )r r s r r~ zNOtherTest.test_answer_challenge_auth_failure.<locals>._FakeConnection.__init__t s
r c x | xj dz
c_ | j dk rt j j S | j dk rdS dS )Nr r r r )r r rB CHALLENGEr s r r zPOtherTest.test_answer_challenge_auth_failure.<locals>._FakeConnection.recv_bytesv s>
a
:??*5??Z1__--sr c d S r rW r s r r zPOtherTest.test_answer_challenge_auth_failure.<locals>._FakeConnection.send_bytes} r r N)rr rs rt r~ r r rW r r r r s sA
r r r )r@ ri r r rB answer_challenger s r "test_answer_challenge_auth_failurez,OtherTest.test_answer_challenge_auth_failurer sk f
/=)4E)/++V 5 5 5 5 5r N)rr rs rt r r rW r r r r e s2 5 5 55 5 5 5 5r r c & | xj dz
c_ d S r )rA )nss r initializerr s GGqLGGGGr c & e Zd Zd Zd Zd Zd ZdS )TestInitializersc t j | _ | j | _ d| j _ d S r )r Managermgrr r rA r s r r zTestInitializers.setUp s4 "*,,($$&& r c j | j | j d S r )r r r r s r r zTestInitializers.tearDown s)
r c V t j }| t |j d | t | j f | | j j d |
| d S r ) r r SyncManagerri TypeErrorr r r rh rA r r )rm r s r test_manager_initializerz)TestInitializers.test_manager_initializer s $ 0 0 2 2 )QWa000 dgZ((( q)))
r c & | t t j d t j dt | j f }| | | | j j d d S )Nr )r )
ri r r r r r r r rh rA rL s r test_pool_initializerz&TestInitializers.test_pool_initializer sr )_%9qIII K$' < < q)))))r N)rr rs rt r r r r rW r r r r sP
* * * * *r r c ` | d }d S # t j $ r Y d S w xY w)NF)block)r r r )r items r _this_sub_processr sB
uu5u!! =
s --c t j } t j t | f }d|_ | | d S rJ )r r r r r r r )r subProcs r
_test_processr sM ! # #E %->eXNNNGGN MMOOO LLNNNNNr c | | z S r rW r s r _afuncr
r r c t j d } | t g d }| | d S )Nr^ r )r r r r^ r r r
)r r r r
r r )r rE s r pool_in_processr sM ! , , ,D ...//AJJLLLIIKKKKKr c 6 e Zd Zd Zed Zd Zd ZdS )
_file_likec " || _ d | _ d S r ) _delegate_pid)rm delegates r r~ z_file_like.__init__ s ! r c h t j }|| j k r|| _ g | _ | j S r )r? r r _cacher s r cachez_file_like.cache s0 ikk $) DI DK{r c : | j | d S r )r rU r s r r0 z_file_like.write s
$ r c x | j d | j g | _ d S )Nr )r r0 r r r r s r flushz_file_like.flush s1 RWWTZ 0 0111 r N)rr rs rt r~ propertyr r0 r rW r r r r s\ X r r c e Zd Zd Zd Zd ZdS )TestStdinBadfiledescriptorc t j t }| | d S Nr )r r r r r )rm r s r test_queue_in_processz0TestStdinBadfiledescriptor.test_queue_in_process s3 &m<<<
r c t j t }| | d S r )r r r r r rL s r test_pool_in_processz/TestStdinBadfiledescriptor.test_pool_in_process s3 #? ; ; ; r c t j }t | d t j fd } d S )NrW c , S r )r )flikes r r z:TestStdinBadfiledescriptor.test_flushing.<locals>.<lambda> s ekkmm r r )r r r r0 r r r )rm sior r# s @r
test_flushingz(TestStdinBadfiledescriptor.test_flushing sY kmm3
E &.C.C.C.CDDD
r N)rr rs rt r r r% rW r r r r sA
' ' ' ' 'r r c e Zd Zed ZddZed ZddZd Zd Z e
j d d Z ed
Z
e
j d d Zd Zd
S )TestWaitc t d D ]T}|r(t j t j dz | |t j f U| d S )Nr3 r )rP r r r r r? r r )r r slowrS s r _child_test_waitzTestWait._child_test_wait sk r % %A
4
6=??U2333
FFAry{{# $ $ $ $ r Fc " ddl m} g }g g }t d D ]}t j d \ }}t j | j ||f }d|_ | | |
|
| | |j |rs || D ]e} |
} |
| -# t $ r, | | | Y bw xY w|s| t# fdt d D }
| ||
d S )
Nr r. r^ Fr r Tc 3 4 K | ]}D ]
}||j fV d S r r )rs rS r rz s r r z%TestWait.test_wait.<locals>.<genexpr> s6 GGGGA1ae*GGGGGGGr r3 )multiprocessing.connectionr/ rP r r r r* r r r rU r_ r r r r r r rh ) rm r) r/ readersmessagesrS r6 r r r rW rz s @r test_waitzTestWait.test_wait s 333333q $ $A"'u555DAq 't/DAt9UUUAAH
GGIII
GGIII NN1 LLOOO OOAF # # # # )T']]
)
))&&((C
OOC(((( NN1%%%GGIIIII )
GGGGeBiiGGGGG 8,,,,,s D3D87D8c L t j }| | t d D ]W}|r(t j t j dz | d|z d X| d S )Nr3 r %s
r} ) rt r rP r r r rz r r )r r r) r rS s r _child_test_wait_socketz TestWait._child_test_wait_socket s MOO 'r 4 4A
4
6=??U2333
IIvz))'22 3 3 3 3 r c ddl m} t j t j df }| }g }g }i }t d D ]i}t j | j
||f } d| _ | |
| | | j jt d D ]3}| \ }
} |
|
g ||
< 4| |rl || D ]^}
|
d } | s*| |
|
C||
| _|ld d t d D d
}
| D ]+}| d | |
,d S ) Nr r. r^ r Tr r c 3 K | ] }d |z V
dS )r2 NrW r s r r z,TestWait.test_wait_socket.<locals>.<genexpr>: s& 99!6A:999999r r3 r} r )r- r/ rt ru r r rv rP r r r3 r r rU r_ r rI r r r r rN rh )rm r) r/ r r r. rz dicrS r r6 r r rW vs r test_wait_socketzTestWait.test_wait_socket s 333333 -"4a!8 9 9}}q $ $A 't/K.2D\; ; ;AAH
GGIII LLOOO OOAF # # # #q A88::DAq NN1 CFF 'T']]
'
'ffRjj 'NN1%%%GGIIIIFMM#&&&& ' 7799uRyy99999@@II 4 4A SXXa[[( 3 3 3 3 4 4r c 0 | d d S rL )r0 r s r test_wait_slowzTestWait.test_wait_slow> s t r c 0 | d d S rL )r8 r s r test_wait_socket_slowz TestWait.test_wait_socket_slowA s d#####r rn c ddl m} d}t j \ }}t j } |||g| }t j |z
}| |g | ||t z
| d |||gd }| ||g d S )Nr r. r r )
r- r/ r r r r rh rJ r r )rm r/ r3 r r r r r8 s r test_wait_timeoutzTestWait.test_wait_timeoutD s 333333 #%%1 dAq67## 5( b!!! 5'I"5666 t dAq62 qc"""""r c V | t j | d S r )r` r r )r ro periods r signal_and_sleepzTestWait.signal_and_sleepV s%
6r c . ddl m} d}d }t j d }t j \ }}t j | j ||f }| | |j t | | d t j } |||j |g|dz } t j |z
}
| | |j g | |
|dz | |
|dz
| d t j } |||j |gd } t j |z
}
| || ||j |g | |
d | d t j } |||j |gd } t j |z
}
| || |||j |g | |
d | | d S )
Nr r. r c & t | d S )Nc t | S r )rR r s r r z>TestWait.test_wait_integer.<locals>.<lambda>.<locals>.<lambda>` s BqEE r )rc )r )r s r r z,TestWait.test_wait_integer.<locals>.<lambda>` s F1// : : : r r r r r g?)r- r/ r rr r r rA r r r^ rF r r_ r r rh r rJ r r r ) rm r/ rW sorted_ro r r r r r r8 s r test_wait_integerzTestWait.test_wait_integer[ sk 333333:: '** #%%1 #4+@*-x
:
:
:
aj#... B //000 dAqz1%x"}55 5( qzl+++ x!|,,, 5(Q,/// t dAqz1%r** 5( ww
A'?'?@@@ s### t dAqz1%r** 5( ww1:q/A'B'BCCC s###
r c T ddl m} t j \ }}t j } ||gd }t j |z
}| |g | |d | | d S )Nr r. r> r r ) r- r/ r r r r rh r r )rm r/ r r r r s r test_neg_timeoutzTestWait.test_neg_timeout s 333333 #%%1 N dA3### N q b!!! 1 r Nr )rr rs rt r r* r0 r3 r8 r: r< r r r> rA rF rH rW r r r' r' s [ - - - -< [!4 !4 !4 !4F $ $ $ W z**# # +*#" [ W z**) ) +*)V r r' c v e Zd Z ej ed d Z ej ed d ZdS )TestInvalidFamilyr c | t 5 t j d d d d d S # 1 swxY w Y d S )Nz\\.\testri rB r rB rD r s r test_invalid_familyz%TestInvalidFamily.test_invalid_family s
z
*
* = = & / / < < < = = = = = = = = = = = = = = = = = = AA A z skipped on non-Windows platformsc | t 5 t j d d d d d S # 1 swxY w Y d S )Nz/var/test.piperL r s r test_invalid_family_win32z+TestInvalidFamily.test_invalid_family_win32 s
z
*
* B B & / /0@ A A A B B B B B B B B B B B B B B B B B BrN N) rr rs rt rC rv r rM r rP rW r r rJ rJ so X_U 011= = 21= X BCCB B DCB B Br rJ c @ e Zd Zed Zed Zd ZdS ) TestFlagsc ^ | t t j d S r )r r rw flagsr r8 s r run_in_grandchildzTestFlags.run_in_grandchild s$ % ""#####r c dd l }t j d \ }}t j | j |f }| | }| | | t t j |f}t |
| d S )Nr Fr r )jsonr r r rV r r r r r rw rT printr )r rX r6 r r grandchild_flagsrT s r run_in_childzTestFlags.run_in_child s #51111 #3+@t L L L 6688 sy!!#34
djj r c dd l }d}t j t j dddd|g }| | d \ }}| || d S )Nr zJfrom test._test_multiprocessing import TestFlags; TestFlags.run_in_child()rZ z-Sz-Or r} )rX r\ check_outputrw r r ra rh )rm rX progr! child_flagsrZ s r
test_flagszTestFlags.test_flags sv +&
^T4tT :< <(,
4;;w3G3G(H(H% % &677777r N)rr rs rt r rV r[ r` rW r r rR rR sW $ $ [$
!
! [
!8 8 8 8 8r rR c * e Zd Zed Zd ZdS ) TestTimeoutsc t j d | d | t j | }| d | d S )Nr r r )r r r r r rB rH )r childr r8 s r
_test_timeoutzTestTimeouts._test_timeout sa
1
3
)0099 #
r c t j } t j d t j d \ }}t j d }t j | j ||j f }|
| | |
d | | }| |
d | | t | t j | d S # t j | w xY w) Nr Tr AF_INETr@ r r r )rt getdefaulttimeoutsetdefaulttimeoutr r rB rD r re r r r rh r rI r$ )rm old_timeoutparentrd r r r8 s r r9 zTestTimeouts.test_timeout sB .00 2 $S ) ) ) + 0 = = =MFE *3393EEA 't/A.3QY-?A A AA
GGIII KKMMM V[[]]C 0 0 0 LLNNN88::D TYY[[# . . . JJLLL
GGIII OOO $[ 1 1 1 1 1F $[ 1 1 1 1s EE0 0FN)rr rs rt r re r9 rW r r rb rb s< [2 2 2 2 2r rb c e Zd Zd ZdS )TestNoForkBombc 8 t j }t j t j t d }|dk rWt j j
|| \ }}}| |d | d| d S t j j
|| \ }}}| | d | |d d S )Nzmp_fork_bomb.pyrd r s RuntimeErrors 123)r rM r? r r r r rA r r assert_python_failurerh rj r r )rm rx r) rd r rn s r test_noforkbombz TestNoForkBomb.test_noforkbomb s
-
/
/w||BGOOH 5 57HII
<< <5KKDRTUULBS S# & & & MM/3 / / / / / <5FFtRPPLBS SZZ\\6 2 2 2 S# & & & & &r N)rr rs rt rp rW r r rm rm s#
'
'
'
'
'r rm c * e Zd Zed Zd ZdS )TestForkAwareThreadLockc B |dk rXt j | j |dz
|f }| | t | n,| t t j | d S )Nr r )
r r rd r r r$ r r r _afterfork_registry)r r r8 r s r rd z TestForkAwareThreadLock.child s q55 'sy!T{KKKA
GGIII JJLLL OOOO IIc$233 4 4 4
r c t j d \ }}t j }t t j }t j | j d|f }| | |
}t | | || d S )NFr r )
r r r ForkAwareThreadLockr rt r rd r r r r$ assertLessEqual)rm r6 r r old_sizer new_sizes r rd z!TestForkAwareThreadLock.test_lock s #E**1 $ & &t/00 #4:QF C C C 6688Q Xx00000r N)rr rs rt r rd rd rW r r rr rr s>
[ 1 1 1 1 1r rr c 6 e Zd Zd Zd Zed Zd ZdS ) TestCloseFdsc H t r%t j S t j }g }|dk r/| | t j | }|dk /|D ]}t j | |S )Nr )r rt detachrU r? dupr )rm r to_closerE s r get_high_socket_fdz TestCloseFds.get_high_socket_fd s =??))++ + ''))BHr''###VBZZ r''
Ir c t r?t j t j t j | d S t j | d S )N)r )r rt rg SOCK_STREAMr r? )rm r s r r zTestCloseFds.close, sI M&.&*<R H H H N N P P P P P HRLLLLLr c t j |t j t j }| | d d S # t $ r }| | Y d }~d S d }~ww xY wr )rt fromfdrg r r r re )r r8 r r r s r _test_closefdszTestCloseFds._test_closefds2 s}
b&.&2DEEA
GGIII IIdOOOOO IIaLLLLLLLLL s *A
B!A<<Bc b t st j d t j \ }}| } t j | j ||f }| | |
}t | | | | | nB# | | | | w xY wt j dk r|
|d d S d}| |t | |j t" j k p
|j |k | d S )Nzrequires fd picklingr rd i6' )r< rC rD r r r r r r r r r$ rM rk r r r r r winerror)rm r r
r r r WSAENOTSOCKs r test_closefdzTestCloseFds.test_closefd< sz <#$:;; ;(-//
$
$
&
&
't/B.4b\; ; ;A
GGIII LLNNN
A OOO JJrNNN LLNNN LLNNNN
JJrNNN LLNNN LLNNNN + - - 7 7 MM!T " " " " " K ! !!W - - - OOAGu{ 2 6 J+ 5q
:
:
:
:
:s
A(C- -?D,N)rr rs rt r r r r r rW r r r{ r{ s\ $ [ : : : : :r r{ c e Zd Z eej ej Zed Z e
j e e
d d d Zed Z e
j e e
d d d ZdS )TestIgnoreEINTRc d }t j t j | | d | }| | | d| j z d S )Nc d S r rW r frames r r2 z-TestIgnoreEINTR._test_ignore.<locals>.handlera r r ready x)r5 r r r r
CONN_MAX_SIZE)r r8 r2 rE s r _test_ignorez TestIgnoreEINTR._test_ignore_ ss
fng... ' IIKK ! s 0011111r r r c t j \ }} t j | j |f }d|_ | | | | d t j
d t j |j
t j t j
d | d | | d t j
d t j |j
t j | | d| j z t j
d | | d S # | w xY w)Nr Tr r i r )r r r r r r r rh r r r r? rA r r5 r r r r r r6 s r test_ignorezTestIgnoreEINTR.test_ignorei sd */11j 't/@.8]< < <AAH
GGIII TYY[[' 2 2 2 JsOOO GAE6> * * * JsOOO IIdOOO TYY[[$ / / / JsOOO GAE6> * * * T__ . .t7I0I J J J JsOOO
FFHHH JJLLLLLDJJLLLLs F F: :Gc > d }t j t j | t j 5 }| |j | }| d d d d d S # 1 swxY w Y d S )Nc d S r rW r s r r2 z6TestIgnoreEINTR._test_ignore_listener.<locals>.handler r r welcome)r5 r r rB rD r r rI )r r8 r2 r r s r _test_ignore_listenerz%TestIgnoreEINTR._test_ignore_listener s
fng...
'
0
0
2
2 a IIai
A
FF9 s ABBBc t j \ }} t j | j |f }d|_ | | | }t j d t j |j t j t j d t j | }| | d | | d S # | w xY w)Nr Tr r )r r r r r r r r r r r? rA r r5 r rB rH rh r )rm r8 r r r rK s r test_ignore_listenerz$TestIgnoreEINTR.test_ignore_listener s */11j 't/I.8]< < <AAH
GGIII iikkG JsOOO GAE6> * * * JsOOO$/66w??F V[[]]I 6 6 6
FFHHH JJLLLLLDJJLLLLs DD4 4E
N)rr rs rt maxr
PIPE_MAX_SIZE
SOCK_MAX_SIZEr r r rC r r4 r5 r r r rW r r r r Z s C-w/DEEM2 2 [2 X335GHH IH, [ X335GHH IH r r c e Zd Zed Zd Zd Zd Zd Zd Z d Z
e j e
j dk d ed
d Zed Zed
Zd ZdS )TestStartMethodc R | t j d S r )r r rM rU s r _check_contextz TestStartMethod._check_context s# /24455555r c | d \ }}| | j |f }| | | }| | | || d S )NFr r ) r r r r r r r rh rM )rm rp r6 r r child_methods r
check_contextz TestStartMethod.check_context s xxux%%1 KKt 2!K > > vvxx s';';'='=>>>>>r c dD ]} t j | }n# t $ r Y $w xY w| | | | | | | t |j d | t |j d | | d S )Nrd rK r rK ) r rS rB rh rM rk ri rg r )rm methodrp s r r7 z TestStartMethod.test_context s 5 $ $F
%1&99
S 1 1 3 3V < < < MM#//++S 1 1 1 j#*> H H H j#*> E E E s # # # # $ $s
((c t j d }n"# t $ r t j d w xY w| t d 5 | g d d d d d S # 1 swxY w Y d S )Nr z forkserver should be availablez&module_names must be a list of stringsr )r rS rB rC rD rX r set_forkserver_preload)rm rp s r test_context_check_module_typesz/TestStartMethod.test_context_check_module_types s F!-l;;CC F F F#$DEE E F
#
#I/W
X
X 2 2 & &yyy 1 1 1 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2s 6A99A= A=c v t j t d}t j } dD ]<} t j |d n# t
$ r Y 'w xY w| t j | t j }| | | | t | j
| | |j
j
| | t |dz
}> t j |d n# t j |d w xY w| |d d S )Nr r Trb r )r r PRELOADrM rg rB rh rS r r rr lower
startswithr r r7 )rm r
old_methodr rp s r test_set_getz TestStartMethod.test_set_get s .w777$577
E9
#4V4HHHHH! H !A!C!CVLLL%133 !5!5!7!7@@@S 2 8 8 : : E Ef M MNNNK(..00;;FCCE E E""?333
,Zt D D D D DO ,Zt D D D D D q)))))s/ F A
F
AF ADF F c t j }t j dk r| |dg d S | |ddgk p|ddgk p|g dk p|g dk d S )Nr- rK rd r )rK rd r )r get_all_start_methodsrw rx rh r )rm methodss r test_get_allz TestStartMethod.test_get_all s !799 <7 " " Wwi 0 0 0 0 0 OOG'8 8 G #'8 8 G #'F'F'F F G $'F'F'F F
H
H
H
H
Hr c ( t j dk r| d t j t j t d }t j j
| \ }}}| }| }|
dk s|dk r5t | t | | d d S d S )Nr z*test only relevant for 'forkserver' methodz
mp_preload.pyokr z(failed spawning forkserver or grandchild)r rM r r? r r r r rA r r r ra r rY rf )rm r) rd r rn s r test_preload_resourcesz&TestStartMethod.test_preload_resources s + - - = = MMF G G Gw||BGOOH 5 5GG|1BB4HH Cjjlljjll ::<<4 3"99 #JJJ #JJJ II@ A A A A A $-9r r- z*Only Spawn on windows so no risk of mixingavoids redundant testing.c dD ]}t j d }t j | }| t |f }d}| t | 5 | d d d n # 1 swxY w Y dD ]}t j D ]}t j | }t j | }| t |f }| | d S )N)rK r rd r zA SemLock created in a fork)
r rS r r r! rX r1 r r r )rm process_methodr process_ctxr rd queue_methods r test_mixed_startmethodz&TestStartMethod.test_mixed_startmethod sq
6 N#/77==??E)5nEEK##;eX#FFA3G'' g>>
4 L"1"G"I"I
'3LAAGGII - 9. I I ''{%'JJ
s 9BB !B c 0 | d d S r r )r r s r _put_one_in_queuez!TestStartMethod._put_one_in_queue s
! r c | d t j | j |f }| | d S rO )r r r r r r )r r r# s r _put_two_and_nest_oncez&TestStartMethod._put_two_and_nest_once sI
! !)1FeXVVV
r c t j }t j | j |f }| | g }| s;| | | ;| t | t ddg d S )Nr r r ) r r r r r r r rU r assertSetEqualr` )rm r r# r s r test_nested_startmethodz'TestStartMethod.test_nested_startmethod
s %''!)1LTYS[\\\
++-- ( NN599;; ' ' ' ++-- (
CLL#q!f++66666r N)rr rs rt r r r r7 r r r r rC rv rw rx rX r r r r rW r r r r s% 6 6 [6? ? ?
$
$
$2 2 2* * *,H H H
B
B
B X_S\W,AC C !<== >=C C& [ [ 7 7 7 7 7r r r, c N e Zd Zd Zd Zd Zd Zd Zed Z d Z
d Z d S )
TestResourceTrackerc J d}t j D ]}| | 5 |dk r
d d d -t j \ }}t j t j dd| || g|gt
j
}t j | t |dd
5 }|
d }|
d }d d d n # 1 swxY w Y t! || | | d | d
} t' j t& j | D ]\}
t! || # t, $ r<} | | j t0 j t0 j f Y d } ~ nd } ~ ww xY w|j d } |j d | }
| | |
| | d|z d d d n # 1 swxY w Y d S )Na+ if 1:
import time, os, tempfile
import multiprocessing as mp
from multiprocessing import resource_tracker
from multiprocessing.shared_memory import SharedMemory
mp.set_start_method("spawn")
rand = tempfile._RandomNameSequence()
def create_and_register_resource(rtype):
if rtype == "semaphore":
lock = mp.Lock()
return lock, lock._semlock.name
elif rtype == "shared_memory":
sm = SharedMemory(create=True, size=10)
return sm, sm._name
else:
raise ValueError(
"Resource type {{}} not understood".format(rtype))
resource1, rname1 = create_and_register_resource("{rtype}")
resource2, rname2 = create_and_register_resource("{rtype}")
os.write({w}, rname1.encode("ascii") + b"\n")
os.write({w}, rname2.encode("ascii") + b"\n")
time.sleep(10)
)r* nooprZ r )r r* )pass_fdsr r( T)r r} zA z< resource was leaked after a process was abruptly terminatedr z8resource_tracker: There appear to be 2 leaked {} objectsz resource_tracker: %r: \[Errno) r& r( r r? piper\ r] rw r r r^ r r r_ r ra r+ r r/ r rb r
r rj r ENOENTEINVALr r r )rm r r* r6 r r r name1name2rd r r rn rW s r test_resource_trackerz)TestResourceTracker.test_resource_tracker# sR < &4 $ P $ PE E ** #
P #
PF?? #
P #
P #
P #
P #
P #
P #
P wyy1 $cn%)4au1M1M&O/0c,6O= = = !T4000 BA JJLL / / 1 1 8 8 A AE JJLL / / 1 1 8 8 A AEB B B B B B B B B B B B B B B !...
2 2 2 2 /0E29; ; A (6666"
ag el/KLLL hmmoo,,W55 &&,f !'# '# h/// &F&NOOOG#
P #
P #
P #
P #
P #
P #
P #
P #
P #
P #
P #
P #
P #
P #
P$ P $ Psh JBJ=A3D<0 J<E JE A"J'F87J8
G> 1G9 3J9G> >B JJ J c ddl m} |j }|@t j |t
j t j |t
j t j
5 t j d | d d d n # 1 swxY w Y |j }t j || t j d t j d }t j
d 5 }t j d | }| | t) j | }~t- j | | |r| t5 | d
|d } | t9 | j t< | d t? | j v n#| t5 | d d d d d S # 1 swxY w Y d S ) Nr _resource_tracker)r r= r- rK T)r alwaysr z resource_tracker: process died)! multiprocessing.resource_trackerr r r? rA r5 rB r wait_processrE rF rG r r r r rS rr r_ r` rg rh ri rj r rh r r
issubclasscategory UserWarningrk message)
rm r
should_dier r rp all_warnro rl the_warns
r check_resource_tracker_deathz0TestResourceTracker.check_resource_tracker_deathk s GFFFFF $ ? GC ( ( ( ? ? ? ?
$
&
& / / !( + + + , , . . . / / / / / / / / / / / / / / / $
V
3 )'22
$D
1
1
1 3X !( + + +--//C KKMMM KKMMMS!!B JLLL bbdd # # #
3 X 222#A;
8+<k J JKKK @#&x'7#8#8!9 : : : : X 222% 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s% #)BB B <D=II
I
c F | t j d d S rH )r r5 r r s r test_resource_tracker_sigintz0TestResourceTracker.test_resource_tracker_sigint s ))&-?????r c F | t j d d S rH )r r5 r; r s r test_resource_tracker_sigtermz1TestResourceTracker.test_resource_tracker_sigterm s ))&.%@@@@@r c F | t j d d S rL )r r5 rB r s r test_resource_tracker_sigkillz1TestResourceTracker.test_resource_tracker_sigkill s ))&.$?????r c ddl m} | |j d |fv }|| z }| | d S )Nr r )r r r r _check_aliver )r8 r r reuseds r _is_resource_tracker_reusedz/TestResourceTracker._is_resource_tracker_reused sh FFFFFF((*** #'D#;6#00222 &r c ddl m} | |j }t j d \ }}t j | j ||f }| | }|
| | | | d S )Nr r Fr r )
r r r r r r r r r r r r r )rm r r r6 r r is_resource_tracker_reuseds r test_resource_tracker_reusedz0TestResourceTracker.test_resource_tracker_reused s FFFFFF((*** $ #51111 #4+K*+S
3
3
3 %&VVXX"
233333r c d}ddt | z
z }| t 5 t j || d d d d S # 1 swxY w Y d S )Nr r r )r ri rB r& register)rm r* too_long_name_resources r test_too_long_name_resourcez/TestResourceTracker.test_too_long_name_resource s !$c%jj(8!9
z
*
* E E %&<e D D D E E E E E E E E E E E E E E E E E Es AA AN) rr rs rt r r r r r rQ r r r rW r r r r s FP FP FPP#3 #3 #3J@ @ @A A A@ @ @ \4 4 4$E E E E Er r c Z e Zd Zed Zd Zd Zej j d Z
dS )TestSimpleQueuec & | | | | | | d S # | w xY wr )r/ r r r` r s r _test_emptyzTestSimpleQueue._test_empty s~ & IIekkmm $ $ $ IIekkmm $ $ $ # # % % % % % # # % % % %s AA: :Bc t j }t j }t j }t j | j |||f }d|_ | | | | |
| | | |
d | |
d | | | d S )Nr TF)r SimpleQueuer r r r r r r r` r/ r rh r r )rm r r r r s r
test_emptyzTestSimpleQueue.test_empty s, +--)/11 - 3 5 5 &# *=>
&&& """ ''' d+++ e,,,
&&& r c | t j }| | d S r )r r r rm r s r rm zTestSimpleQueue.test_close s. +--
r c t j }| | |j j | |j j d S r )r r r r _readerr; _writerr s r test_closedzTestSimpleQueue.test_closed sQ +--
,---
,-----r N) rr rs rt r r r rm rA r cpython_onlyr rW r r r r sl & & [& 0
\ . . . . .r r c e Zd Zd ZdS )TestPoolNotLeakOnFailurec dg G fdd }| t d 5 t j dt
j | }| | d d d n # 1 swxY w Y |
t d D d S ) Nr c 6 e Zd Z fdZfdZd Zd Zd ZdS )RTestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.FailingForkProcessc \ d| _ d | _ d | _ | d S )Nz Fake Process)r) r r rU )rm rO forked_processess r r~ z[TestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.FailingForkProcess.__init__ s2 * $
!
''-----r c J dk rt d dz d| _ d S )Nr Manually induced OSErrorr r )r r )rm will_fail_ins r r zXTestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.FailingForkProcess.start s2 1$$!"<=== ! &
r c d| _ d S )Nstoppingr r s r r z\TestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.FailingForkProcess.terminate
s
'
r c . | j dk r d| _ d S d S )Nr stoppedr r s r r zWTestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.FailingForkProcess.join
s" :++!*DJJJ ,+r c . | j dk p
| j dk S )Nr r r r s r r z[TestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.FailingForkProcess.is_alive s zY.J$*
2JJr N)rr rs rt r~ r r r r )r r s r FailingForkProcessr sy
.
.
.
.
.
'
'
'
'
'
(
(
(
+
+
+
K
K
K
K
Kr r
r r )r )contextc 3 > K | ]}| V d S r r )rs r# s r r zITestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.<genexpr> s. CCw ""CCCCCCr ) rX r r r r rC r MagicMockr r r rB )rm r
r r r s @@r test_release_unused_processesz6TestPoolNotLeakOnFailure.test_release_unused_processes sY K K K K K K K K K K K0
#
#G-G
H
H $))!X]5L5L* 6M 6, 6,) - -A
GGIII
FFHHH
CC2BCCC C C E E E E Es A(B&&B*-B*N)rr rs rt r rW r r r r s( $E $E $E $E $Er r c e Zd ZdZej j Zd Zd Z e
d Z e Z d Z
d Ze
d Zd Ze
d Zd'd Ze
d Zd'd
Ze
d Zd(dZd Ze
d Zd Ze
d Zd Ze
d Z d Z e
d Z d)dZ d Z e
d Z!d Z"e
d Z#d Z$e
d Z%d! Z&e
d" Z'd# Z(e
d$ Z)d% Z*d&S )*TestSyncManagerTypesa} Test all the types which can be shared between a parent and a
child process by using a manager which acts as an intermediary
between them.
In the following unit-tests the base type is created in the parent
process, the @classmethod represents the worker process and the
shared object is readable and editable between the two.
# The child.
@classmethod
def _test_list(cls, obj):
assert obj[0] == 5
assert obj.append(6)
# The parent.
def test_list(self):
o = self.manager.list()
o.append(5)
self.run_worker(self._test_list, o)
assert o[1] == 6
c x | | _ | j d | _ d S r )
manager_classr r r r s r r zTestSyncManagerTypes.setUp6 s4 ))++ r c | j K| j r2| j | j | j d | _ d | _ d S r )r r r r r r r s r r z TestSyncManagerTypes.tearDown; si 9 TY%7%7%9%9 I ! ! ! INN r c , t j d S r )r
reap_childrenr( s r r z TestSyncManagerTypes.setUpClassC s r c r t | j t j }t j dd D ])}t
t j dk r d S *t j |z
}dt _ t j
dt j d|dd d S )
Nr Ferrorr T"multiprocessing.Manager still has active children after .1f seconds) r$ r r r r rb r r r environment_altered
print_warning)rm
start_timer r s r wait_proc_exitz#TestSyncManagerTypes.wait_proc_exitI s TY ^%%
'5999 M MA?24455:: ; !!J.B*.G ' ! #L%4%D%F%F#L #L;="K#L #L #L
M
M
M
M
Mr c t j ||f | _ d| j _ | j | | | j j d d S )Nr Tr )r r r r r r# rh r )rm workerr& s r
run_workerz TestSyncManagerTypes.run_workerZ sj #+6HHH +Q/////r c | | | d d S Nrv )r/ r r r& s r r z TestSyncManagerTypes._test_eventa s1
r c | j }| | | j | | d d S r( )r r r` r& r r/ rm rP s r r z TestSyncManagerTypes.test_eventh sL L (!,,, u
r c . | d S r r_ r) s r
_test_lockz TestSyncManagerTypes._test_locko
r r^ c t | j | }| | j | | | t |j d S r )r r r& r. r` ri r1 rm lnamerP s r rd z TestSyncManagerTypes.test_locks s\ (GDL% ( ( * * +++ , 22222r c V | | d S r r_ r` r) s r _test_rlockz TestSyncManagerTypes._test_rlocky
r c v t | j | }| | j | d S r )r r r& r5 r1 s r rg z TestSyncManagerTypes.test_rlock~ s8 (GDL% ( ( * * (!,,,,,r c . | d S r r- r) s r rp z$TestSyncManagerTypes._test_semaphore r/ r rr c t | j | }| | j | | d S r )r r r& rp r` )rm snamerP s r rs z#TestSyncManagerTypes.test_semaphore sC (GDL% ( ( * * ,a000 r c 2 | d d S )Nrv )r: )rs r s r rw z+TestSyncManagerTypes.test_bounded_semaphore s "455555r c V | | d S r r4 r) s r _test_conditionz$TestSyncManagerTypes._test_condition r6 r c n | j }| | j | d S r )r r r& r= r+ s r test_conditionz#TestSyncManagerTypes.test_condition s2 L " " $ $ ,a00000r c . | d S r )r" r) s r
_test_barrierz"TestSyncManagerTypes._test_barrier s r c p | j d }| | j | d S r )r r r& rA r+ s r r
z!TestSyncManagerTypes.test_barrier s4 L # # *A.....r c > |5 d d d d S # 1 swxY w Y d S r rW r) s r
_test_poolz TestSyncManagerTypes._test_pool sq s c r | j d }| | j | d S )Nr^ r )r r r& rD r+ s r test_poolz TestSyncManagerTypes.test_pool s6 L * * +++++r c d S r rW r) s r _test_queuez TestSyncManagerTypes._test_queue r r c t | j | d }| d | d | | j | d S )Nr r r )r r r r& rH )rm qnamerP s r
test_queuez TestSyncManagerTypes.test_queue sX (GDL% ( ( + + a a (!,,,,,r c 0 | d d S )Nr* )rL r s r test_joinable_queuez(TestSyncManagerTypes.test_joinable_queue s (((((r c ` | | |D ]}d S r )r reverse)r r& rE s r
_test_listz TestSyncManagerTypes._test_list s:
A r c | j }| d | | j | | t
| d d S )Nr r )r r rU r& rQ rh r r+ s r r z TestSyncManagerTypes.test_list s\ L +++ Q#####r c d S r rW r) s r
_test_dictz TestSyncManagerTypes._test_dict rI r c | j }d|d< | | j | | t | d d S )Nr rW r )r r r& rT rh r r+ s r r z TestSyncManagerTypes.test_dict sV L % +++ Q#####r c 0 | d d S ru )r` r) s r _test_valuez TestSyncManagerTypes._test_value s
r c | j dd }| | j | | |j d | | d d S )NrS r r )r r r& rW rh r r r+ s r rX z TestSyncManagerTypes.test_value sl L sA & & (!,,, !$$$ !$$$$$r c d S r rW r) s r _test_arrayz TestSyncManagerTypes._test_array rI r c v | j dddg }| | j | d S )NrS r r )r ru r& rZ r+ s r rx z TestSyncManagerTypes.test_array s: L sQF + + (!,,,,,r c d S r rW r) s r _test_namespacez$TestSyncManagerTypes._test_namespace rI r c | j }d|_ d|_ | | j | d S r )r r rE rF r& r] r+ s r r z#TestSyncManagerTypes.test_namespace s@ L " " $ $ ,a00000r Nri )rr )r )+rr rs rt ru r r r r r r r r r r# r& r r r. rd r5 rg rp rs rw r= r? rA r
rD rF rH rL rN rQ r rT r rW rX rZ rx r] r rW r r r r s * $,8M
[ MM M M"0 0 0 [ [3 3 3 3 [- - - - [
6 6 6 [1 1 1 [/ / / [
, , , [ ) ) ) [ $ $ $ + + [+$ $ $ [
% % % # # [# - - - [1 1 1 1 1r r c 6 e Zd Z ed d ZdS )TestNamedResourcezspawn specific test.c t j }| t j | t |dd 5 }| t
j d d d d n # 1 swxY w Y t j | \ }}}|
|| d d S )Nr r r aW import multiprocessing as mp
ctx = mp.get_context('spawn')
global_resource = ctx.Semaphore()
def submain(): pass
if __name__ == '__main__':
p = ctx.Process(target=submain)
p.start()
p.join()
r ) r r r_ r r r0 textwrapdedentr r r ra )rm r r rd r rn s r test_global_named_resource_spawnz2TestNamedResource.test_global_named_resource_spawn s ! (&111
&#
0
0
0
A
GGHO %
%5f== C
#**W"5"566666s (A33A7:A7N)rr rs rt rX re rW r r r` r` s: !7887 7 987 7 7r r` c < e Zd Zd Z ed d ZdS ) MiscTestCasec X t j | t t j ddg d S )NSUBDEBUGr )extra not_exported)r check__all__r r r s r test__all__zMiscTestCase.test__all__" s= T?/:Q+5|*D F F F F F Fr r c t j dd \ }}}| |d | || d d S )Nr zif 1:
import sys
sys.executable = None
assert "multiprocessing" not in sys.modules, "already imported!"
import multiprocessing
import multiprocessing.spawn # This should not fail
r r rb )r r rh r ra )rm rd r rn s r ,test_spawn_sys_executable_none_allows_importz9MiscTestCase.test_spawn_sys_executable_none_allows_import' sh %5
F
C
Q #**W"5"566666r N)rr rs rt rm rX ro rW r r rg rg ! sN F F F
! !<==7 7 >=7 7 7r rg c : e Zd Zed Zed ZdS ) BaseMixinc t j j t j f| _ d S r )r r# _danglingr r danglingr( s r r zBaseMixin.setUpClass? s6 '/9>>@@!+00224 r c t j t t j j t | j d z
}|r(dt j _ t j d| d }t t j t | j d z
}|r(dt j _ t j d| d }d S )Nr TDangling processes: r Dangling threads: ) rA r r^ r` r r# rs rt r r! r )r r r s r r zBaseMixin.tearDownClassD s
!!!/9::S a =Q=QQ F/3DL , !"D"D"D E E E i)**S a -A-AA B/3DL , !"@w"@"@ A A Ar N)rr rs rt r r r rW r r rq rq > sH 4 4 [4 [ r rq c e Zd ZdZej Zej Z eej Z eej Z eej
Z
eej Z eej Z eej
Z
eej Z eej Z eej Z eej Z eej Z eej Z eej Z eej Z eej Z eej Z eej Z eej Z eej ZdS )r r N)rr rs rt r r r rB rQ r r r r r r r r* r^ rf rr rv r r r r ru rS rt rW r r r r W sz D %G +J"l?#BCCO!\/"@AAN"l?#BCCO!\/"@AAN <, - -D <, - -D L . / /E L !>??M <, - -D L . / /E _ 677I#|O$DEE _ 677I L . / /El?233G L . / /E L . / /E|O 455H|O 455HHHr r c , e Zd ZdZej Z e ej d Z e ej d Z
e ej d Z e ej d Z e ej d Z
e ej d Z e ej d Z e ej d Z e ej d
Z e ej d Z e ej d Z e ej d
Z e ej d Z e ej d Zed Ze fd Ze fd Z xZS ) ManagerMixinr z
manager.Queuezmanager.JoinableQueuez manager.Lockz
manager.RLockzmanager.Semaphorezmanager.BoundedSemaphorezmanager.Conditionz
manager.Eventzmanager.Barrierz
manager.Valuez
manager.Arrayz manager.listz manager.dictzmanager.Namespacec & | j j |i |S r )r r )r rN r s r r zManagerMixin.Pool s s{ ....r c x t t j | _ d S r )r r r r r r s r r zManagerMixin.setUpClass s-
%-// r c t j }t j dd D ](}t t j dk r nP)t j |z
}dt _ t j dt j d|dd t j
| j d
k rPdt j _ t j d t j | j | j | j d | _ t# d S ) Nr Fr r Tr r r r r z5Shared objects which still exist at manager shutdown:)r r r rb r r r r r! ri rj r _number_of_objectsrA _debug_infor r r r )r r" r r r s r r zManagerMixin.tearDownClass sy
^%%
'5999 M MA?24455:: ; !!J.B*.G ' ! #L%4%D%F%F#L #L;="K#L #L #L
M
M
M
; ) ) + +q 0 0 04DL , ! #9
:
:
: !#+"9"9";"; < < <
r ) rr rs rt r r r r operator
attrgetterr r* r^ rf rr rv r r r r ru r r r r r r r r` ra s @r rz rz p s, D %G H(X( 99 : :E H 0X 01H I IJJM 8'H'77 8 8D H(X( 99 : :E,,-@AABBI x 3 34N O OPP,,-@AABBI H(X( 99 : :Eh*x*+<==>>G H(X( 99 : :E H(X( 99 : :E 8'H'77 8 8D 8'H'77 8 8D,,-@AABBI/ / [/ 0 0 0 0 [0 [ r rz c e Zd ZdZej j Zej j Z eej j Z eej j
Z
eej j Z eej j Z eej j
Z
eej j Z eej j Z eej j Z eej j Z eej j Z eej j Z eej j Z eej j Z eej j Z eej j ZdS ) ThreadsMixinr N)rr rs rt r r dummyr rB rQ r r r r r r* r^ rf rr rv r r r r ru rW r r r r se D #+G &1J"l?#8#HIIO"l?#8#HIIO <-2 3 3D <-2 3 3D L .4 5 5E L !6!DEEM <-2 3 3D L .4 5 5E _ 2 <==I#|O$9$JKK _ 2 <==I L .4 5 5El?0899G L .4 5 5E L .4 5 5EEEr r c | d }t }h d}| D ]4\ }}t |t s t |t
r|t
u r;|j D ]} |r| |k r |rd| z |dd z }
|| dz } G d d|| t j } | dk r t j d | } |
x| _ | _
|| _ | | |
< t |t j r2|r G d
d|t } |x| _ | _
|| _ | | |< 6d d gd gfd }
fd }|
| d
< || d< d S )Nrr > r r r Withr Mixinc e Zd ZdS *install_tests_in_module_dict.<locals>.TempNr rW r r Tempr s Dr r r r c e Zd ZdS r r rW r r r z*install_tests_in_module_dict.<locals>.Temp s r c t j t t j t j j d< t j d< t j d d< t j d n%# t $ r t j dz w xY wt j d r7 t j } n"# t" $ r t j d w xY wt% t' j t j t. d S ) Nr r Tr` rb z start method not supportedlinuxz1OSError raises on RLock creation, see issue 3111!)r r r r# _cleanuprs r r rM rg rB rC rD rw rx r rf r rG r get_temp_dirr r r )rc rt old_start_methodrP s r setUpModulez1install_tests_in_module_dict.<locals>.setUpModule sz .w777 ((***%-7<<>> )..00 - >$ O O O C ,\ F F F F F C C C#L$A%B C C
C C < " "7 + + ;
;&,..
;
;
; ' ): ; ; ;
; !!! "$$--i88888s B0 0"C5D D(c f d} t j t j d d t t j j t d z
}|r*d} dt j _ t j d| d }t t j t d z
}|r*d} dt j _ t j d| d }| rt j d t j
d S ) NFr Trb rv r rw r )rA r r^ r rg r` r# rs r r! r r r r _cleanup_tests)
need_sleepr r rt r s r tearDownModulez4install_tests_in_module_dict.<locals>.tearDownModule s
!!!()9!)<DIIII/9::S!=M=MM F J/3DL , !"D"D"D E E E i)**S!-=-== B J/3DL , !"@w"@"@ A A A JsOOO ++-----r r r )globalsr r r r r r
capitalizerC TestCaser requires_hashdigestrr rt rs r@ ) remote_globsrP only_type
exclude_typesrs local_globs ALL_TYPESr) basetype_newnamer r r r rt r s ` @@r install_tests_in_module_dictr sC j)J))K333I!'')) & &
d$%% dL ) ) &|## +
-
- )!3!3 5#3#3#5#55QRR@#E$4$4$6$6$@A 4(9 I%%D>=eDDTJJD4;;
1",(, W%%
- h /
0
0 &
tV
04 4DMD - (DO!%L d|H v9 9 9 9 9 9 9,. . . . . .: #.L %3L!"""r SemLockzSemLock not availabler z
Linux onlyc e Zd Zd ZdS ) SemLockTestsc G d dt j }dt j } |ddd|d }t | d S )Nc e Zd ZdS )3SemLockTests.test_semlock_subclass.<locals>.SemLockNr rW r r r r ' rp r r ztest_semlock_subclass-r r r3 F)r r r? r
sem_unlink)rm r r) r s r test_semlock_subclassz"SemLockTests.test_semlock_subclass& st &. 5 55 GAq"dE * *##D)))))r N)rr rs rt r rW r r r r " s# * * * * *r r )r1 NrH )rC
unittest.mockr r rc r r r rw r? ri r rT r5 rv rt r r r\ r r r r rg rE test.supportrA test.support.script_helperr r r r r r r r
import_moduler *skip_if_broken_multiprocessing_synchronizer r- r multiprocessing.dummymultiprocessing.heapmultiprocessing.managersrv multiprocessing.queuesr r
HAVE_SEND_HANDLEr< ImportError multiprocessing.sharedctypesr r r r HAS_SHMEMr HAVE_ASAN_FORK_BUGrD r r r! r$ r) r& r+ r r rK r r r r r
r r
HAVE_GETVALUErx r r/ r4 r@ r. r ctypesr8 r9 r: r; r@ rG rX r rZ rz r r r r r r r r r r r[ rl rz r r r r r r r? rn r r r r r r rB r r r re ri rk r| r r r+ r r r r r r r r r r r r r r r r r r> rO rZ r rp r r r r rg r r r r r r r r r r
r r r r' rJ rR rb rm rr r{ r r rv r r r r r` rg rq r rz r r r4 r rW r r <module>r s
! ! ! ! ' ' ' ' ' ' & & & & & & " " " " " " & & & & & & & & & & & & ) ) ) ) ) ) ( ( ( ( ( ( /=./ABB 2 2 4 4 4 ! ! ! ! )))))) .MM MMM 88888888 ------II IIIMMMM
FFF _ (
]
^
^^
* * * 7g0000005 5 5
O
1#2 Hh#0 Hh ( G , 6? ? ?
+ + + + + +# # #
BJ} % %EE EEE =
> )============= ) ) )I$((E(Hzzz)
K K K 2L L L L LX . L L L@ 0 0 0 0 0F 0 0 0" 6 6
*
*
* L 8 L 8 L 8 L 8 L 8< L 8 L 8 L 8f /) ,Q7 Q7 Q7 Q7 Q7l Q7 Q7 Q7n $ $ $@ @ @ @ @ @ @ @J
03@ 3@ 3@ 3@ 3@\ 3@ 3@ 3@ld d d d d\ d d dN 5W 5W 5W 5W 5W 5W 5W 5W@& & & & & & & &.
6 6 6 6 6F 6 6 6r x1 x1 x1 x1 x1< x1 x1 x1|C3 C3 C3 C3 C3 C3 C3 C3LM3 M3 M3 M3 M3 M3 M3 M3fY/ Y/ Y/ Y/ Y/l Y/ Y/ Y/~ $ $ $
$ $ $ $ $F $ $ $ % $ $ $ $: $ $ $ l! l! l! l! l! l! l! l!\ & & & & &L & & &PB B B B B l B B B P I H H H H H H H H H V , , , , ,I , , ,
56 * * * 56; ? ? ? 53- @ @ @4> 4> 4> 4> 4>\ 4> 4> 4>v
/ / / / /; / / / kI 6 6 6K K K K KK K K K
{ # # #
. . . . . . . .b $ #E**22 22 22 22 22, 22 22 +*22p 599G/ G/ G/ G/ G/l G/ G/ G/R 8 8 8 8 8L 8 8 8D. . . . ., . . .`L L L L L L L Ld ]$JKK# #E**@ @ @ @ @| @ @ +* LK@Lb b b b b b b bP
9
5) 5) 5) 5) 5) 5) 5) 5)p Y HII# #E**{J {J {J {J {J {J {J +* JI{JBu u u u uL u u ux% % % % %h' % % %V+) +) +) +) +)< +) +) +)J 6 6 6 6 6\ 6 6 6DE E E E E) E E E& $ #E**5 5 5 5 5! 5 5 +*5B $ #E*** * * * *x( * * +**<
*' ' ' ' '!2 ' ' '*g g g g gx g g gZ
B
B
B
B
B)
B
B
B 8 8 8 8 8! 8 8 8@ 2 2 2 2 28$ 2 2 2D ' ' ' ' 'X& ' ' '"1 1 1 1 1h / 1 1 1><: <: <: <: <:8$ <: <: <:DA A A A Ah' A A AF7 7 7 7 7h' 7 7 7D (=? ?]E ]E ]E ]E ]E(+ ]E ]E? ?]E@0. 0. 0. 0. 0.h' 0. 0. 0.f&E &E &E &E &Ex 0 &E &E &ER $ #E**f1 f1 f1 f1 f18, f1 f1 +*f1R7 7 7 7 7) 7 7 747 7 7 7 78$ 7 7 7: 26 6 6 6 6Y 6 6 628 8 8 8 8 9 8 8 8 v6 6 6 6 69 6 6 62 @E\4 \4 \4 \4~ WW -y999;RSS (,77* * * * *8$ * * 87 TS* * *sf
C) )C32C37
D D D D D#"D#'D, ,D65D63G G
G
G/.G/