python (3.12.0)
Browse
Usage
Versions
͑e. T 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 jH d
Z% e jL 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/m0Z0 d d l)m1Z1 d d
l)m2Z2 e2jf Z4 d dl6m7Z7m8Z8 dZ9 d dl)m:Z: dZ; d dl<Z< e jz d r e j| d d Z?d Z@d ZAe j dk( r d dl)mCZC d ZDe1j ZFdZGdZHeHrd\ ZIZJZKnd \ ZIZJZKe j ZMd ZN eOe%d d ZPej d k( ZRd ZS e j d! ZUd#d$gZV d d%lWmXZXmYZYmZZZm[Z[ d& Z]d' Z^ G d( d)e j Z` G d* d+e\ Za G d, d-e\ Zbd. Zc G d/ d0 Zd G d1 d2eb Ze G d3 d4e)j Zg G d5 d6eb Zhd7 Zid8 Zj G d9 d:eb Zk G d; d<eb Zl G d= d>eb Zm G d? d@eb Zn G dA dBeb Zo G dC dDe\ ZpdE Zq G dF dGe\ Zr G dH dIe\ Zs G dJ dKeb Zt G dL dMeb Zu G dN dOeb Zv G dP dQeb ZwddRZxdS ZydT ZzdU Z{ G dV dWe\ Z| G dX dYe} Z~dZ Z G d[ d\eb Zd] Zd^ Z G d_ d`eb Z G da dbeb Zd dcl,mZmZmZ G dd dee\ Zdf Z G dg dhe Z G di dje Zej dkel ej dmedno ej dpeeq G dr dseb Z ej Zdt Z G du dve Zej dwel G dx dye Zej dw dzZ G d{ d|eb Z e j* d} G d~ deb Z e?d Z G d deb Z G d deb Z G d deb Z G d deb Z e j8 e4d e j* d} G d deb Z G d deb Z G d deX Z G d deb Z e j8 e;d e j* d} G d deb Z G d deb Z G d de j Z G d deb Z G d deb Z G d de j Z e j* d} G d de j Z e j* d 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 jt ej 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 jt ee%d dث e jt ej dk7 dګ G dۄ de j Zy# e5$ r dZ4Y w xY w# e5$ r dZ9Y w xY w# e5$ r dZ;Y w xY w# e5$ r dZ<Y w xY w# d"ZUY ^xY w# e5$ r e\ZXdxZYxZZZ[Y `w xY w) N)support)hashlib_helper)
import_helper) os_helper)
script_helper)
socket_helper)threading_helper)warnings_helper_multiprocessing)waitAuthenticationError)util) reductionF)ValuecopyT)
shared_memory)addressz(libasan has a pthread_create() dead lockc $ | j d S )Nlatin)encode)ss N/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/_test_multiprocessing.pyr r W s 88G c t | t j j r!| j | j y y N)
isinstancemultiprocessingqueuesQueueclose join_thread)queues r close_queuer# [ s2 % //556
7r c . t j | y r )r r! )processs r join_processr& a s )r posix)resource_trackerc 4 t j | | y r )r( _CLEANUP_FUNCS)namertypes r _resource_unlinkr- j s ''.t4r 皙?)g=
ףp=?gffffff?gffffff?)r. r. r. @HAVE_BROKEN_SEM_GETVALUEwin32c . ||dk rd }t | g| S )N r )handletimeouts r wait_for_handler7 s" w} ' ""r SC_OPEN_MAX __main__z$test.test_multiprocessing_forkserver) Structurec_intc_double
c_longlongc d} t j d }|dk( s|| k\ ryt j
d| z # t t f$ r Y yw xY w)zACheck that the system supports enough semaphores to run the test.r9 SC_SEM_NSEMS_MAXNzHThe OS doesn't support enough semaphores to run the test (required: %d).)ossysconfAttributeError
ValueErrorunittestSkipTest) nsems_minnsemss r check_enough_semaphoresrJ sl I
-.
{ey(
>@I J K K
J ' s < A
Ac 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 F t j fd }|S )Nc | t j x}dk7 rt j d|d | i |S )Nspawn
start_method=z, not 'spawn'; )r get_start_methodrF rG )argskwargs start_methodreason test_items r spawn_check_wrapperzKonly_run_in_spawn_testsuite.<locals>.decorator.<locals>.spawn_check_wrapper sG / @ @ BB wN ''=</ (QRR d-f- -r ) functoolswraps)rU rV rT s ` r decoratorz.only_run_in_spawn_testsuite.<locals>.decorator s& # .
$ .
#"r )rT rY s ` r only_run_in_spawn_testsuiter[ s # r c \ e Zd ZdZ ej
ej dk( d d Zy)TestInternalDecoratorszBLogic within a test suite that could errantly skip tests? Test it!r1 z test requires that fork exists.c t j dk7 rt j d t d d }t j d } t j dd | j d t j d
d | j t j 5 } | d d d | j dt j | j d t |j t j |d y # t
$ r }| j
d| Y d }~d }~ww xY w# 1 sw Y xY w# t j |d w xY w) NrN z'only run in test_multiprocessing_spawn.ztesting this decoratorc yN rZ rZ r r return_four_if_spawnzUTestInternalDecorators.test_only_run_in_spawn_testsuite.<locals>.return_four_if_spawn s r z.expected decorated `def` not to raise; caught T
allow_noneforcera forkrO )
r rP rF rG r[ Exceptionfailset_start_method assertEqual assertRaisesassertInstr exception)selfrb errorig_start_methodctxs r test_only_run_in_spawn_testsuitez7TestInternalDecorators.test_only_run_in_spawn_testsuite sA + + - 8##$MN N N
()A
B
C
, < < M L , ,WD A 1 3Q 7 , ,V4 @""8#4#45
'$&
' MM2C
4F G MM/3s}}+= > , ,->d K N IIFseL M M N
'
'
, ,->d Ks= D, A$E# :EAE# , E5EEE E# #E<N) __name__
__module__ __qualname____doc__rF skipIfsysplatformrt rZ r r r] r] s1 LX__S\\W,.OPL QLr r] c e Zd Zd Zd Zy)
TimingWrapperc || _ d | _ y r )funcelapsed)rp 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 )rp rQ kwdsts r __call__zTimingWrapper.__call__ sM NN 0 499d+d+ >>+a/DL4>>+a/DLs A A"Nru rv rw r r rZ r r r} r} s 0r r} c & e Zd ZdZd Zd Zd ZeZy) BaseTestCase) processesmanagerthreadsc 8 t r| j ||d y y N )
CHECK_TIMINGSassertAlmostEqualrp abs r assertTimingAlmostEqualz$BaseTestCase.assertTimingAlmostEqual s " "1a + r c P || }| j || S # t $ r Y y w xY wr )rk NotImplementedError)rp valuer rQ ress r assertReturnsIfImplementedz'BaseTestCase.assertReturnsIfImplemented s9 0+C ##E3/ / # s %%c t d )Nz#shouldn't try to pickle a test case)r )rp rQ s r
__reduce__zBaseTestCase.__reduce__ s !"GHHr N)ru rv rw
ALLOWED_TYPESr r r
__reduce_ex__rZ r r r r s 7M,0I Mr r c | j S # t $ rA | j cY S # t $ r% | j cY cY S # t $ r t w xY ww xY ww xY wr ) get_valuerD _Semaphore__value_valuer rp s r r r sg *~~ * *)) ) *
*{{"!
*))
* **s9 A *A A AA A AAA c e Zd Zd Zy)
DummyCallablec & |j d y N put)rp qcs r r zDummyCallable.__call__& s
ar N)ru rv rw r rZ r r r r % s r r c 2 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 d.d 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 d/d* Z/d+ Z0d, Z1d- Z2y )0 _TestProcessr r c | j dk( r*| j dj | j | j }|j }| j |j
| j |j | j |t | j t | dkD | j |j t j | j |j d y )Nr test not appropriate for {}r )TYPEskipTestformatcurrent_processauthkey
assertTrueis_alivedaemonassertIsInstancebyteslenrk identrB getpidexitcode)rp currentr s r test_currentz_TestProcess.test_current/ s 99 ! MM7>>tyyI J&&(// ((*+ GNN*+ gu- G q() 4 ))40r c | j dk( r | j d| j t j t j j t j t j g}|D ]_ }| j | | j }|j |j | j |j d a y )Nr ztest not appropriate for r )
r r rz
executabler pathlibPathset_executableProcessstartjoinrk r )rp pathspathps r test_set_executablez _TestProcess.test_set_executable= s 99 ! MM 5dii[A B NN NN ! ! # LL (
,D % A
GGI
FFH QZZ + ,r cpuc dddgdf}t t f}t j || }|D ] \ }}| j || 5 | j d }| j
| j |||f }d|_ |j |j }| j || |j t | d d d y # 1 sw Y xY w)Nr rn r )rQ args_typetargetrQ T)listtuple itertoolsproductsubTestr r
_test_argsr r getrk r r# ) rp
args_cases
args_types
test_casesrQ r r r
child_argss r test_args_argumentz _TestProcess.test_args_argumentL s T*
E]
&&z:>
)
OD) 49 =
JJqMLLiD >RLS UUW
T2A
s
B CC$ c & |j | y r r )clsr args r r z_TestProcess._test_argsa s
c
r c | j dk( r*| j dj | j | j | j }| j |j | j j | j | j d }| j |j | j | j d }| j |j y )Nr r r Tr r F)
r r r r _testrk r r r assertFalse)rp proc0proc1proc2s r test_daemon_argumentz!_TestProcess.test_daemon_argumente s 99 ! MM7>>tyyI J DJJ / t';';'='D'DE DJJt < % DJJu = &r c < | j }|j | |j | |j |j | j dk7 r@|j t |j
|j |j y y )Nr )r r r+ r r r pid)r r rQ r r s r r z_TestProcess._testq sl %%' d d gll 88y
EE%( )
EE'++ !r c p | j dk( r*| j dj | j | j | j | j d \ }}| j
| j |f }|j |j |j \ }}| j || j j | j |t j | j || j j y )Nr r Fduplexr )r r r assertIsNoneparent_processPiper _test_send_parent_processr r recvrk r r rB r r+ )rp rconnwconnr
parent_pid parent_names r test_parent_process_attributesz+_TestProcess.test_parent_process_attributes{ s 99 ! MM7>>tyyI J $--/0yyy. u LL > >eXL N "'**,
K T%9%9%;%?%?@ RYY[1 d&:&:&<&A&ABr c r ddl m} |j | j | j g y )Nr r )multiprocessing.processr sendr r+ r r r s r r z&_TestProcess._test_send_parent_process s( :
N$((.*:*?*?@Ar c p | j dk( r*| j dj | j | j d \ }}| j | j
|f }|j
|j t j s t d |j }| j |d |j |j |j t j s t d |j }| j |d y )
Nr r Fr r r6 z(Could not communicate with child processalive not alive)r r r r r _test_create_grandchild_processr pollr LONG_TIMEOUTAssertionErrorr rk terminater )rp r r r parent_process_statuss r test_parent_processz _TestProcess.test_parent_process s 99 ! MM7>>tyyI J
yyy. u LL77ui
I zz'"6"6z7 !KL L %
.8
zz'"6"6z7 !KL L %
. <r c | j | j |f }|j t j d y )Nr i, )r _test_report_parent_statusr r sleep)r r r s r r z,_TestProcess._test_create_grandchild_process s0 KKs = =UIK N
3r c ddl m} |j | j rdnd | j t
j |j | j rd y d y )Nr r r r r )r r r r r r
SHORT_TIMEOUTr s r r
z'_TestProcess._test_report_parent_status sZ :
n . 7 7 97{K g&;&; <
n . 7 7 97K{Kr c | j d }| j }|ddf}ddd}d}| j | j ||| }d|_ | j }| j d k7 r&| j |j |j | j |j d
| j |j d | j || j | j t | j t u | j |j d |j! | j |j d | j |j d | j# || j | j |j% |dd | j |j% | | j |j% |j& | j d k7 rT| j |j% |j | j |j% |j( |j+ | j |j d | j |j d
| j || j t- | y ) Nr gR Q@)hellobye SomeProcess)r rQ rR r+ Tr Fr )r Eventr r r r r rk r r assertNotInactive_childrenr typer r r rm r r+ r r r# )rp r erQ rR r+ r r s r test_processz_TestProcess.test_process s. JJqM JJL1ay D) LL::Dd
&&( 99 ! QYY 8 u- 4( D 0 0 23 T 1 1 34<= T* T* t,
a--/0 $qr(+ &) !&&) 99 ! QUUWgoo 6 QUUWaee , Q' u- D 0 0 23Ar zneeds native_idc | j dk( r*| j dj | j t j j
}| j
d }| j | j |f }|j |j }|j t | | j || y )Nr r r r )r r r threading main_thread native_idr r "_test_process_mainthread_native_idr r r r# assertNotEqual)rp current_mainthread_native_idr r child_mainthread_native_ids r !test_process_mainthread_native_idz._TestProcess.test_process_mainthread_native_id s 99 ! MM7>>tyyI J'0'<'<'>'H'H$ JJqM LL G GqdL S %&UUW" A 8:TUr c b t j j }|j | y r )r r r r )r r mainthread_native_ids r r! z/_TestProcess._test_process_mainthread_native_id s$ ( 4 4 6 @ @ "#r c . t j d y )Nd r r r s r _sleep_somez_TestProcess._sleep_some s
3r c . t j | y r r* )r delays r _test_sleepz_TestProcess._test_sleep s
5r c " | j dk( r*| j dj | j | j | j d_ j
| j j d | j | j | j j d t j }| j |d d | j |j d | j j d | j |d d | j |j d | j j d t! j" d | t% t& d rfd
}t' j& t& j( | } t' j* d | j | d t' j* d t' j& t& j( | n| j | d | j |j d | j j d | j- | j j j S # t' j* d t' j& t& j( | w xY w)
Nr r r Tr r3 rA r alarmc t dz )Nzjoin took too long: %s RuntimeError)rQ r s r handlerz+_TestProcess._kill_process.<locals>.handler s "#;a#?@@r
F)r r r r r, r r rk r rm r r r} r r r r r hasattrsignalSIGALRMr1 r )rp methr r5 old_handlerr s @r
_kill_processz_TestProcess._kill_process s 99 ! MM7>>tyyI J LL 0 0L 1 t,
a--/0 T* QVV$ a$' $$T\\37 t, b4( $$T\\37 t,
1
Q 67 #
A --@K
; R . Q
fnnk: TVT * $$T\\37 u- D 0 0 23 zz Q
fnnk:s ,K ;Lc | j t j j }t j
dk7 r"| j
|t j y y Nnt) r< r r r rB r+ rk r8 SIGTERMrp r s r test_terminatez_TestProcess.test_terminate. sD %%o&=&=&G&GH
77d? X 7 r c | j t j j }t j
dk7 r"| j
|t j y y r> ) r< r r killrB r+ rk r8 SIGKILLrA s r test_killz_TestProcess.test_kill3 sD %%o&=&=&B&BC
77d? X 7 r c t j }| j t | t
u | j |dk\ y # t $ r d}Y Bw xY wr )r cpu_countr r r int)rp cpuss r test_cpu_countz_TestProcess.test_cpu_count8 sR ",,.D
T
c)* " # D s A AAc | j t | j t | j t
j t f }| j || j d|_ |j | j || j |j | j || j y Nr T)
rk r r r r r r DELTAr r r rm r rp r s r test_active_childrenz!_TestProcess.test_active_children@ s d 2 2 45t< LL
%L : D 0 0 23
a--/0 D 0 0 23r c |j | t | dk rTt d D ]E }| j | j |||gz f }|j |j
G y y Nr r )r r ranger _test_recursionr r )r r idir s r rT z _TestProcess._test_recursionM sl
2 r7Q;1X
KK ..eRV_
r c R | j d \ }}| j |g t j t g }|j r0|j
|j |j r0g dgddgddgdgddgddgg}| j || y )NFr r r ) r rT r r rN r appendr rk )rp r r resultexpecteds r test_recursionz_TestProcess.test_recursionX s yyy. u UB'
5jjl MM%**, ' jjl
cAAcAA
*r c & |j d y )N $@r4 r events r _test_sentinelz_TestProcess._test_sentinell s
4r c | j dk( r*| j dj | j | j }| j | j
|f }| j
t 5 |j d d d |j | j |j |j }| j |t | j t |d |j! |j | j# t |d y # 1 sw Y xY w)Nr r r r3 r r )r r r r r r` rl rE sentinelr
addCleanupr r rI r r7 setr )rp r_ r rb s r
test_sentinelz_TestProcess.test_sentinelp s 99 ! MM7>>tyyI J
LL 3 35(L C
z
*
JJ :: h, 3?@
!<= s =
D88ENc R ||j t j | y r )r rz exit)r rcr s r _test_closez_TestProcess._test_close s =
EEG r c | j dk( r*| j dj | j | j }| j | j
d|i }d|_ |j | j |j d | j t 5 |j d d d |j d |j | j |j d | j |j d |j | j t 5 |j d d d | j t 5 |j d d d | j t 5 |j! d d d |j t# j$ | }~t' j( | j+ | d t- | y # 1 sw Y ^xY w# 1 sw Y xY w# 1 sw Y xY w# 1 sw Y xY w)Nr r r )r rR TFr )r r r r r ri r r rk r rl rE r r r r r weakrefrefgccollectassertIsr# )rp r r wrs r
test_closez_TestProcess.test_close s 99 ! MM7>>tyyI J JJL LL 0 0#qL B t,
z
*
GGI
d u- Q'
z
*
JJL
z
*
FFH
z
*
KKM
[[^
bdD!A+ s0 5H"H/>H;,I"H,/H8;IIwalltimec | j dk( r*| j dj | j t j }|dk( rdnd}t | D cg c] }| j
| j d ! }}|D ] }|j |D ]
}t | |D ] }| j |j d t | D cg c] }| j
| j }}|D ] }|j t j d
|D ] }|j |D ]
}t | t j" d k7 rit$ j& g}t( j* d k( r |j- t$ j. |D ] }| j1 |j | y y c c}w c c}w )
Nr r rN r r) ){Gz?r r r MbP?r? darwin)r r r r rP rS r r/ r r& rk r r, r r r rB r+ r8 r@ rz r{ rX rE rm )rp smNrV procsr exitcodess r test_many_processesz _TestProcess.test_many_processes s 99 ! MM7>>tyyI J
-
-
/w AC ($ T%5%5G D $ $ A
GGI A O ,A QZZ + , ($ T%5%5 6 $ $ A
GGI
5 A
KKM A O
77d? .. )I||x' &.. 1
5
ajj)4
5
%$$s $$G##G c z t }t j | }| j }| j |||f }~|j |j
t j | j | d | j |j d t | y )Nr r )
r rk rl r r r r rm rn ro rk r r# )rp r rp r r s r test_lose_target_refz!_TestProcess.test_lose_target_ref s O
[[^ JJL LLAL /
bdD! !$Ar c j |j t j |j y r )r r fd_countr )rp evtr s r _test_child_fd_inflationz%_TestProcess._test_child_fd_inflation s i "#
r c B | j dk( r*| j dj | j t j }|dk( r | j dj | d}| j }| j
}t | D cg c]! }| j | j ||f # }}|D ] }|j t | D cg c] }|j }}| j t t | d| |j |D ] }|j t! | y c c}w c c}w # |j |D ] }|j t! | w xY w)Nr r rg r r r )r r r r rP r r rS r r r r rk r rd r r# ) rp rw rx r r rV ry r fd_countss r test_child_fd_inflationz$_TestProcess.test_child_fd_inflation se 99 ! MM7>>tyyI J
-
-
/
<
MM7>>rB C
jjl JJL ($ T%B%B#q R $ $ A
GGI */(3Q3I3 SY 0!Y ?
GGI
N$ 4
GGI
Ns$ "&E "
E* /E%'E* %E* *4F c fd}fd}t j | j t j |d j y )Nc P t j d j y )N ?r r rd r s r func1z2_TestProcess._test_wait_for_threads.<locals>.func1 s JJsO GGIr c P t j d j y )N )r r clearr s r func2z2_TestProcess._test_wait_for_threads.<locals>.func2 s JJrN IIKr r Tr )r Threadr )rp r r r s ` r _test_wait_for_threadsz#_TestProcess._test_wait_for_threads s? &,,.d399;r c P | j dk( r*| j dj | j | j }| j | j
|f }|j
|j | j |j y )Nr r r )
r r r r r r r r r is_set)rp r procs r test_wait_for_threadsz"_TestProcess.test_wait_for_threads su 99 ! MM7>>tyyI Jjjl||4#>#>cV|L
%r c |j D ]B \ }}|dk( r%t j }|j nd }t t
|d D |j
y )Nr )itemsioStringIOr setattrrz rd )rp r break_std_streams stream_nameactionstreams r _test_error_on_stdio_flushz'_TestProcess._test_error_on_stdio_flush sY #4#:#:#< , K Cd + , r c t j d g}|d j dD ] }|D ] }t t | }t t || | j
}| j | j |f }|j |j | j |j | j |j d t t || y # t t || w xY w)Nr stdoutstderrr )r r r getattrrz r r r r r r r r rk r )rp streamsr r
old_streamr r s r test_error_on_stdio_flush_1z(_TestProcess.test_error_on_stdio_flush_1 s ;;=$'
/
:K!
: $S+ 6
[&1 : **,C <<t/N/N.1V ( 5DJJLIIKOOCJJL1$$T]]A6Cj9
:
: Cj9s
B C55Dc dD ] }dD ] }t t | } | j }| j | j |||if }|j |j
| j |j | j |j d t t || y # t t || w xY w)Nr )r remover r ) r rz r r r r r r r rk r r )rp r r r r r s r test_error_on_stdio_flush_2z(_TestProcess.test_error_on_stdio_flush_23 s 0 :K-
: $S+ 6
: **,C <<t/N/N.1K3H-I ( KDJJLIIKOOCJJL1$$T]]A6Cj9
: : Cj9s B B>>Cc N t j | |j y r r )rp r r. s r _sleep_and_set_eventz!_TestProcess._sleep_and_set_eventD s
5 r c | j dk( r*| j dj | j t j }|dk7 r | j dj | ddlm} |j d}| j }| j | j ||f }|j |j }t j || t j |dz | j }| j | j |f } | j | j# | j% |j' | j) | j* d |j# | j% |j' | j- |j* d y )
Nr r
forkserverr ) _forkserverr r @)r )r r r r rP multiprocessing.forkserverr ensure_runningr r r r _forkserver_pidrB rD r r r r r rk r rm )
rp signumrw r r. r r r evt2r s
r check_forkserver_deathz#_TestProcess.check_forkserver_deathI sU 99 ! MM7>>tyyI J
-
-
/
MM7>>rB C:""$ jjl||4#<#<C<|P
))
V
53; zz| D$=$=TG L
& +
%
dmmX.r c B | j t j y r )r r8 SIGINTr s r test_forkserver_sigintz#_TestProcess.test_forkserver_siginto s ##FMM2r c j t j dk7 r | j t j y y r> )rB r+ r r8 rE r s r test_forkserver_sigkillz$_TestProcess.test_forkserver_sigkills s$
77d? ' ' 7 r )r Nr3 )3ru rv rw r r r r requires_resourcer classmethodr r r r r r r r
r rF
skipUnlessr _HAVE_THREAD_NATIVE_IDr% r! r, r/ r< rB rF rK rP rT r[ r` re ri rq r{ r} r r r r r r r r r r r rZ r r r r + s ,M 1
, W u% & (
'
C B B=2
L L &P X99;LMV NV $ $ 1f8
8
# 4 +( >
@ W z*!5 +!5F >
<
<
& @B :&:" $/L38r r c $ e Zd Zd Zd Zd Zd Zy) _UpperCaserc t j j | t j \ | _ | _ y r )r r r r
child_conn parent_connr s r r z_UpperCaser.__init__ s. ((.,;,@,@,B))r c | j j t | j j d D ]+ }| j j |j
- | j j y r )r r iterr r r upperrp r s r runz_UpperCaser.run s\ doo**D1 ,A OO + , r c l | j j | | j j S r )r r r r s r submitz_UpperCaser.submit s+ a $$&&r c | j j d | j j | j j y r )r r r r r s r stopz_UpperCaser.stop s8 d# r N)ru rv rw r r r r rZ r r r r } s C '
r r c B e Zd ZdZd Zd Zed Zed Zd Z y)_TestSubclassingProcessr c
t }d|_ |j | j |j d d | j |j d d |j |j
y )NTr HELLOworldWORLD)r r r rk r r r )rp
uppercasers r test_subclassingz(_TestSubclassingProcess.test_subclassing sg ]
**73W= **73W=r c " | j dk( r*| j dj | j t j }| j t j | | j | j |f }|j |j t |d 5 }|j }| j d| | j d| | j d| d d d y # 1 sw Y y xY w) Nr r r utf-8encodingZeroDivisionErrorztest_multiprocessing.pyz 1/0 # MARKER)r r r r TESTFNrc unlinkr _test_stderr_flushr r openreadrm )rp testfnr frq s r test_stderr_flushz)_TestSubclassingProcess.test_stderr_flush s 99 ! MM7>>tyyI J!! ((&1||4#:#:&|K
&7
+ /q&&(C MM-s 3 MM3S 9 MM.# . / / /s
5ADDc t j |t j t j z t j z }t |ddd t
_ ddz y )Nwr Fr closefdr r )rB r O_WRONLYO_CREATO_EXCLrz r )r r fds r r z*_TestSubclassingProcess._test_stderr_flush sA
WWVR[[2:: 5 A
B"cGUC
!r c t j |t j t j z t j z }t |ddd t
_ t j | y )Nr r Fr )rB r r r r rz r rg )r rT r r s r _test_sys_exitz&_TestSubclassingProcess._test_sys_exit sF
WWVR[[2:: 5 A
B"cGUC
r c | j dk( r*| j dj | j t j }| j t j | g ddfD ] }| j | j ||f }d|_ |j t | | j |j d t |d 5 }|j }d d d | j j! t# | t% j | g d
}|D ] \ }}| j' | 5 | j t( j* | }d|_ |j t | | j |j | d d d y # 1 sw Y xY w# 1 sw Y xY w) Nr r r r z ignore thisr Tr r r )))Tr )Fr )) r )r r )rZ r rQ )r r r r r rc r r r r r r& rk r r r rstriprn rB r rz rg ) rp r rT r r contentcasesrQ rZ s r
test_sys_exitz%_TestSubclassingProcess.test_sys_exit s 99 ! MM7>>tyyI J!! ((&1
F D$7$7vv>N OAAH
GGI O QZZ +fw/
#1&&(
# W^^ -s6{ ; IIf $ 7ND( 4 (
7LLtL< Q X6
7
7 7
#
#
7
7s F?A G ?G G N)
ru rv rw r r r r r r r rZ r r r r s> "M/"
&7r r c ` t | d r| j S | j dk( S )Nemptyr )r7 r qsize)r s r queue_emptyr s( q'wwywwyA~ r c ` t | d r| j S | j |k( S )Nfull)r7 r r )r maxsizes r
queue_fullr s( q&vvxwwyG##r c e Zd Zed Zd Zed Zd Zed Zd Z d Z
ed Z d Z d
Z
d Zd Zd
Zd Zy)
_TestQueuec |j t d D ] }|j |j y )N )r rS r rd )r r" child_can_startparent_can_continuerV s r _test_putz_TestQueue._test_put s6 q A IIK !r c d}| j | }| j }| j }| j | j |||f }d|_ |j | j
t | d | j
t || d |j d |j dd |j ddd |j d d |j d
dd |j d t j t | j
t | d | j
t || d t |j }t |j }| j t j" |d d | j% |j& d | j t j" |d dd | j% |j& d | j t j" |d | j% |j& d | j t j" |d dt( | j% |j& t( | j t j" |d dt* | j% |j& d | j t j" |d dt,
| j% |j& t, |j/ |j1 | j
t | d | j
t || d |j3 t5 | y )Nr r r TFr r r ra r r r )r r r r r r rk r r r
put_nowaitr r rN r} rl pyqueueFullr r TIMEOUT1TIMEOUT2TIMEOUT3rd r r r# )rp MAXSIZEr" r r r r r s r test_putz_TestQueue.test_put s
7
+ **, "jjl||>> *=>
U+T2 E73U;
!
!T
!T4
!U
!UD!
5 U+U3 E73T:EII&"5#3#34
',,Q6 $$S[[!4 ',,Qt< $$S[[!4 ',,
A6 $$Z%7%7; ',,Qh? $$S[[(; ',,Qx@ $$S[[!4 ',,QhG $$S[[(; " U+T2 E73U; Er c |j |j d |j d |j d |j d |j y )Nr r ra r )r r rd r r" r r s r _test_getz_TestQueue._test_get< sF
!
!
!
! !r c | j }| j }| j }| j | j |||f }d|_ |j | j
t | d |j |j t j t | j
t | d | j
|j dd d | j
|j d d | j
|j d d | j
|j d | j
t | d t |j }t |j }| j! t" j$ |d | j' |j( d
| j! t" j$ |dd | j' |j( d
| j! t" j$ | | j' |j( d
| j! t" j$ |dt* | j' |j( t* | j! t" j$ |dt, | j' |j( d
| j! t" j$ |t. | j' |j( t. |j1 t3 | y ) Nr TFr r r r ra r r )r r r r r r rk r rd r r r rN r
get_nowaitr} rl r Emptyr r r r r r r# )rp r" r r r r r s r test_getz_TestQueue.test_getF s[
**, "jjl||>> *=>
U+T2 "
5 U+U3
4.2 4 !, 1-q1 ))+Q/ U+T2EII&"5#3#34
'--e4 $$S[[!4 '--eT: $$S[[!4 '--4 $$Z%7%7; '--dH= $$S[[(; '--eX> $$S[[!4 '--h? $$S[[(; Er c H t dd D ] }|j | y )Nr6 r )rS r )r r" rV s r
_test_forkz_TestQueue._test_fork{ s" r2 A IIaL r c | j }t d D ] }|j | t j t
| j
| j |f }d|_ |j t d D ]" }| j |j | $ | j t j |j d |j t! | y )Nr6 r Tr F)r rS r r r rN r r r r rk r rl r r r r# )rp r" rV r s r test_forkz_TestQueue.test_fork s
r A IIaL
5
LLuhL ? r -A UYY[! , - '--E: Er c @ | j } | j |j d |j d | j |j d |j d | j |j d |j
| j |j d |j
| j |j d t | y # t $ r | j d Y w xY w)Nr z qsize method not implementedr r r )r rk r r r r r r# rp r s r
test_qsizez_TestQueue.test_qsize s JJL : QWWY *
a A& a A& A& A&A # : MM8 9 :s D D D c t |j d D ]+ }t j t |j - y r )r r r r rN task_done)r r objs r _test_task_donez_TestQueue._test_task_done s1 t$ C JJu
KKM r c | j }t d D cg c] }| j | j |f " }}|D ] }d|_ |j t d D ] }|j
| |j |D ] }|j
d |D ] }|j t | y c c}w )Nra r Tr6 )
JoinableQueuerS r r$ r r r r r# )rp r" rV workersr s r test_task_donez_TestQueue.test_task_done s ""$ "!H& <<t';';5(<K & & AAH
GGI r A IIaL
A IIdO A
FFH E#&s %Cc t j 5 d}t |dz dd 5 }|j d d d d t j
t
j 5 t | d d d d d d y # 1 sw Y NxY w# t j $ r | j d Y Cw xY w# 1 sw Y HxY w# 1 sw Y y xY w)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
DirsOnSysPathrB getcwd
__import__r r ri )rp module_namer s r test_no_import_lock_contentionz)_TestQueue.test_no_import_lock_contention s
! 3:KkE)3A
Q
,,RYY[9
33 {+
3 3 3
}} 3II 2 33
3
3 3 3sW C
B/C
*B>, B7C
B
C
$B;8B>:B;;B>>C C
Cc t j }t j }| j t
j |j dd t j |z
}| j |d t | y )NTg?r. )
r r r r rl r r r assertGreaterEqualr# )rp r r deltas r test_timeoutz_TestQueue.test_timeout sb ! ! # '--e< 5(
u-Ar c | j dk7 r*| j dj | j G d dt }t j
j
5 | j }|j | |j d | j |j t
j t | d d d t j
j
5 | j d }|j | |j d | j |j d | j |j t
j | j |j! t | d d d y # 1 sw Y xY w# t $ r Y yw xY w# 1 sw Y y xY w) Nr r c e Zd Zd Zy)F_TestQueue.test_queue_feeder_donot_stop_onexc.<locals>.NotSerializablec t r )rD r s r r zQ_TestQueue.test_queue_feeder_donot_stop_onexc.<locals>.NotSerializable.__reduce__ s $$r Nru rv rw r rZ r r NotSerializabler8 s
%r r; Tr r r )r r r objecttestr captured_stderrr r r r r r# rk r r r )rp r; r s r "test_queue_feeder_donot_stop_onexcz-_TestQueue.test_queue_feeder_donot_stop_onexc sf 99 # MM7>>tyyI J %f % \\
)
)
+
A
EE/# $
EE$K OOAEE'*?*?E @ A N \\
)
)
+
1
%A
EE/# $
EE$K
A.
OOAEE'*?*?E @ A OOAGGI & N '
s> 'A2F<?:G: GAG<G GGGGG c | j dk7 r*| j dj | j G d dt G fddt j
j } }t j j 5 |t j }|j | |j d | j |j t j d d d | j |j | j |j y # 1 sw Y @xY w)
Nr r c e Zd ZdZd Zd Zy)K_TestQueue.test_queue_feeder_on_queue_feeder_error.<locals>.NotSerializablezMock unserializable objectc d| _ d| _ y 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=5r c d| _ t NT)rE rD r s r r zV_TestQueue.test_queue_feeder_on_queue_feeder_error.<locals>.NotSerializable.__reduce__ s )-&$$r N)ru rv rw rx r r rZ r r r; rB s ,
>
%r r; c & e Zd ZdZe fd Zy)E_TestQueue.test_queue_feeder_on_queue_feeder_error.<locals>.SafeQueuez1Queue with overloaded _on_queue_feeder_error hookc P t | t rt | rd|_ y y y rH )r rD rF )r r# r; s r _on_queue_feeder_errorz\_TestQueue.test_queue_feeder_on_queue_feeder_error.<locals>.SafeQueue._on_queue_feeder_error s) q.1"38;?C8 9 2r N)ru rv rw rx staticmethodrL )r; s r SafeQueuerJ s C
@
@r rN )rs Tr )r r r r< r r r r= r r> get_contextr r r r rE rF )rp rN not_serializable_objr r; s @r 'test_queue_feeder_on_queue_feeder_errorz2_TestQueue.test_queue_feeder_on_queue_feeder_error s 99 # MM7>>tyyI J %f % @..44 @ / 0
\\
)
)
+ Bo 9 9 ;<A
EE& '
EE$K OOAEE'*?*?E @ A
B
,>>? ,MMN B Bs
A-E E c l t j t j fD ]q }|j | j t
d 5 |j
d d d d | j t
d 5 |j d d d s y # 1 sw Y ;xY w# 1 sw Y xY w)Nz is closedfoo)r r r& r assertRaisesRegexrE r r r s r $test_closed_queue_put_get_exceptionsz/_TestQueue.test_closed_queue_put_get_exceptions1 s &&(/*G*G*II A
GGI''
K@
e
''
K@
s B B* B' *B3 N)ru rv rw r r r r r r r r r$ r( r1 r5 r? rQ rU rZ r r r r s " " 9v " "3j 8
,3* @$OLr r c e Zd Zd Zd Zd Zy) _TestLockc F | j }| j |j d | j |j d d | j |j d | j t
t j f|j y NTF)Lockrk acquirereleaserl rE r ThreadErrorrp locks r test_lockz_TestLock.test_lock> sq yy{ . e,e4 . :y'<'<=t||Lr c | j }| j |j d | j |j d | j |j d | j |j d | j |j d | j |j d | j t
t f|j y rH )RLockrk r[ r\ rl r r4 r^ s r
test_rlockz_TestLock.test_rlockE s zz| . . . . . . ><8$,,Gr c P | j 5 d d d y # 1 sw Y y xY wr rZ r s r test_lock_contextz_TestLock.test_lock_contextO s#
YY[ s %N)ru rv rw r` rc rf rZ r r rW rW < s MHr rW c $ e Zd Zd Zd Zd Zd Zy)_TestSemaphorec Z | j dt | | j |j d | j dt | | j |j d | j dt | | j |j d d | j dt | | j |j d | j dt | | j |j d | j dt | y )Nr Tr r F)r r rk r[ r\ rp sems r _test_semaphorez _TestSemaphore._test_semaphoreV s ''9c: - ''9c: - ''9c: U+U3 ''9c: - ''9c: - ''9c:r c $ | j d }| j | | j |j d | j dt
| | j |j d | j dt
| y )Nr r ra ) Semaphorerl rk r\ r r rj s r test_semaphorez _TestSemaphore.test_semaphorec sn nnQ S! - ''9c: - ''9c:r c H | j d }| j | y Nr )BoundedSemaphorerl rj s r test_bounded_semaphorez%_TestSemaphore.test_bounded_semaphorek s ##A& S!r c | j dk7 r*| j dj | j | j d }t |j
}| j
|d d | j |j d | j
|dd d | j |j d | j
|dt d | j |j d | j
|dt d | j |j t | j
|t d | j |j t y )Nr r r Fr3 Tr ) r r r rn r} r[ rk r r r r r )rp rk r[ s r r5 z_TestSemaphore.test_timeouts s 99 # MM7>>tyyI JnnQ , / $$W__c: -u5 $$W__c: 159 $$W__a8 x0%8 $$W__h? 2E: $$W__h?r N)ru rv rw rl ro rs r5 rZ r r rh rh T s ;;"@r rh 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 Zy)_TestConditionNc |j |j |j | |j |j y r )r[ r\ r )r condsleepingwokenr6 s r r z_TestCondition.f s5 '
r c t d D ]) } | |k( r n t j t + t j t | j || y # t $ r Y 8w xY wNr6 )rS r r r rN r )rp r r rV s r assertReachesEventuallyz&_TestCondition.assertReachesEventually sk r A
6U? #
JJu
5 ''t4 '
s
A$$ A10A1c & | j dk( rs |j j |j j z
}| j |d | j |j
j d y y # t $ r Y y w xY w)Nr r )r _sleeping_countr _woken_countrk _wait_semaphorer )rp rx sleeperss r check_invariantz _TestCondition.check_invariant s 99 #
0 0 : : < - - 7 7 9 : 1- !5!5!?!?!A1E $ '
s A1B BBc | j }| j d }| j d }| j | j |||f }d|_ |j | j
|j t j | j |||f }d|_ |j | j
|j |j |j t j t | j dt | |j |j! |j# t j t | j dt | |j |j! |j# t j t | j dt | | j% | |j y )Nr r Tr r ) Conditionrn r r r r rc r r r r[ r r rN r r notifyr\ r )rp rx ry rz r s r test_notifyz_TestCondition.test_notify sq ~~ >>!$q! LLdHe-DL E DFF$%1H I
5 ''9e<
5 ''9e<
5 ''9e<
T" r c z | j }| j d }| j d t d D ] }| j | j ||t
f }d|_ |j | j |j t j | j ||t
f }d|_ |j | j |j t d D ] }|j t d D ] }j | j dt | j | t d D ] }| j | j ||f }d|_ |j | j |j t j | j ||f }d|_ |j | j |j t d D ] }|j t! j" t$ | j dt |j |j' |j) | j+ fdd | j | y )Nr r r Tr c t S r r rz s r <lambda>z0_TestCondition.test_notify_all.<locals>.<lambda> Yu-= r )r rn rS r r r r r rc r r r r[ r r r r r rN
notify_allr\ r} rp rx ry rV r r rz s @r test_notify_allz _TestCondition.test_notify_all s; ~~ >>!$q! q $A DFF#'5("C EAAH
GGI OOAFF # '+Xuh&GIAAH
GGI OOAFF # $ q A q A MMO ''9e<
T" q $A DFF$%1H IAAH
GGI OOAFF # dHe5LMAAH
GGI OOAFF # $ q A
5 ''9e<
$$%=qA
T"r c J | j }| j d }| j d t d D ] }| j | j ||f }d|_ |j
| j |j t j | j ||f }d|_ |j
| j |j t d D ] }|j t j t | j dt |j |j# d |j% | j' fdd |j |j# d |j% | j' fd
d |j |j# d |j% | j dt | j) | y ) Nr r r Tr r )nc t S r r r s r r z._TestCondition.test_notify_n.<locals>.<lambda>4 r r ra c t S r r r s r r z._TestCondition.test_notify_n.<locals>.<lambda>; r r )r rn rS r r r r rc r r r r[ r r rN r r r r\ r} r r s @r
test_notify_nz _TestCondition.test_notify_n s ~~ >>!$q! q $A DFF$%1H IAAH
GGI OOAFF # dHe5LMAAH
GGI OOAFF # $ q A
5 ''9e<
a
$$%=qA
a $$%=qA
a ''9e<
T"r c
| j }t |j }|j |t }|j | j
|d | j |j t y rD ) r r} r r[ r r\ rk r r )rp rx r r s r r5 z_TestCondition.test_timeoutG s[ ~~ TYY' 8n e$ $$T\\8<r c |5 d_ |j |j fd }|rj dk7 rt j d d d d y # 1 sw Y y xY w)Nr c " j dk( S r` r states r r z0_TestCondition._test_waitfor_f.<locals>.<lambda>U EKKN r ra r )r r wait_forrz rg )r rx r rY s ` r _test_waitfor_fz _TestCondition._test_waitfor_fP sS
EK KKM]]#:;FU[[A - s AA A(zneeds sharedctypesc v | j }| j dd | j | j |f }d|_ |j |5 |j
fd }| j | | j j d d d d t d D ]G }t j d |5 xj d z
c_ |j d d d I t | | j |j d y # 1 sw Y xY w# 1 sw Y xY w)
NrV rA r Tc " j dk( S Nr r r s r r z-_TestCondition.test_waitfor.<locals>.<lambda>d r r r ra rt r )r r r r r r r r rk r rS r r r r& r )rp rx r rY rV r s @r test_waitforz_TestCondition.test_waitforY s ~~
3# LL 4 4D%=L I
-]]#:;F OOF # U[[! , -
q A JJt
q
Q Q' - -
s AD# &D/#D,/D8 c |j |5 d}t j }|j fd| }t j |z
}|s|dz |cxk r|dz k r
n nd|_ d d d y # 1 sw Y y xY w)Nr. c " j dk( S r` r r s r r z8_TestCondition._test_waitfor_timeout_f.<locals>.<lambda>w r r r g333333?r] T)r\ r r r r )r rx r successrk rZ dtrY s ` r _test_waitfor_timeout_fz&_TestCondition._test_waitfor_timeout_fq sw
%H !B]]#:H]MF !B&Bhnr CHtO C $
% % %s A!A>>Bc j | j }| j dd }| j dd }| j d }| j | j ||||f }d|_ |j
| j |j t j t d D ]G }t j d |5 |xj d z
c_ |j d d d I t! | | j |j y # 1 sw Y zxY w)
NrV r Fr Tr r rt r )r r rn r r r r r r[ r r rS r r r r r& )rp rx r r rk r rV s r test_waitfor_timeoutz#_TestCondition.test_waitfor_timeout} s ~~
3"**S%(nnQ LL < < #UGS 9
; G,@,@ AB q A JJt
q
Q
&
s &D))D2 c |5 |j d d d t j d |%t j |t
j y y # 1 sw Y FxY wr )r r r rB rD r8 r )r r r s r _test_wait_resultz _TestCondition._test_wait_result sJ
HHJ
1
? GGC ' s AA"c J t | t r(t j dk7 rt j
}nd }| j
}|5 | j |j d | j |j d | j | j ||f }|j | j |j d |!| j t |j d |j d d d y # 1 sw Y y xY w)Nr1 r r. r < )r ProcessesMixinrz r{ rB r r r r r r r r rl KeyboardInterruptr )rp r r r s r test_wait_resultz _TestCondition.test_wait_result s dN + 0G))+CC NN
QVVAY ' QVVC[ ) D$:$:!S JA
GGI OOAFF2J '!!"3QVVR@
FFH s
CDD"r )ru rv rw r r r} r r r r r5 r rF r HAS_SHAREDCTYPESr r r r r rZ r r rv rv s 5 +Z<#|0#d= X)+?@( A(. % % X)+?@' A'. ( (r rv c * e Zd Zed Zd ZddZy)
_TestEventc V t j t |j y r )r r r rd r^ s r _test_eventz_TestEvent._test_event s
8
r c | | j }t |j }| j |j d | j |d d | j |j d | j |t d | j |j t |j | j |j d | j | d | j |j d | j |t d | j |j d |j | j | j |f }d|_ |j | j | d |j y )NFr3 Tr )r r} r rk r r r r rd r r r r r r )rp r_ r r s r
test_eventz_TestEvent.test_event sF
UZZ(
/
cE* $$T\\37 h / $$T\\8<
. & $$T\\37 h . $$T\\37
LL 0 0xL @ & r Nc | j }| j dk( rr| j t | d |j | j t | d |j | j t | d y | j dk( rG| j t | d |j | j t | d y y )Nr z<Event at .* unset>z<Event at .* set>r z(<EventProxy object, typeid 'Event' at .*)r r assertRegexreprrd r )rp r_ s r test_reprz_TestEvent.test_repr s
99 # T%[*@ A IIK T%[*> ? KKM T%[*@ A
YY)
# T%[*U V IIK T%[*U V $r )returnN)ru rv rw r r r r rZ r r r r s !F Wr r c * e Zd Zd Zd Zd Zd Zd Zy)
_DummyListc t j j t j d }t j
}| j
||f d| j d< y )NrV r )r heap
BufferWrapperstructcalcsizerZ __setstate__
_lengthbuf)rp wrapperr_ s r r z_DummyList.__init__ sO !&&44V__S5IJ ##% 7D/* r c ~ |\ | _ | _ | j j j d | _ y )NrV )_wrapper_lockcreate_memoryviewcastr )rp r s r r z_DummyList.__setstate__ s/ &+#
--99;@@Er c 2 | j | j fS r )r r r s r __getstate__z_DummyList.__getstate__ s
tzz**r c t | j 5 | j dxx dz
cc< d d d y # 1 sw Y y xY wNr r r r )rp _s r rX z_DummyList.append s2
ZZ $ OOA ! # $ $ $s .7c d | j 5 | j d cd d d S # 1 sw Y y xY wr r r s r __len__z_DummyList.__len__ s*
ZZ &??1% & & &s &/N)ru rv rw r r r rX r rZ r r r r s F+$&r r c . t j d y )Nrt r* rZ r r _waitr s JJtr c 6 e Zd ZdZd dZd Zd Zd Zd Zd Z y)
Bunchz
A bunch of threads.
c || _ || _ || _ |j | _ |j | _ |j
| _ |s| j j g }t | D ]F }|j | j }d|_ |j |j | H d } t j | | | | _ y)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 2 | D ] }|j y r )r )r r s r finalizez Bunch.__init__.<locals>.finalize( s
r N)r rQ r DummyListstartedfinishedr _can_exitrd rS r taskr r rX rk r
_finalizer)
rp namespacer rQ r wait_before_exitr rV r r s
r r zBunch.__init__ s **, !++-
" * NN q A!!!3AAH
GGI NN1 "**47Cr c x t j }| j j | | j | j
| j j | | j j d y # | j j | | j j d w xY w)N ) rB r r rX r rQ r r r rp r s r r z
Bunch.task. s iik C + DFFDII MM % NN #
MM % NN #s B 8B9c t | j | j k r.t t | j | j k r-y y r )r r r r r s r wait_for_startedzBunch.wait_for_started8 s3 $,, $&&( G $,, $&&(r c t | j | j k r.t t | j | j k r-y y r )r r r r r s r wait_for_finishedzBunch.wait_for_finished< s3 $-- 466) G $-- 466)r c 8 | j j y r )r rd r s r do_finishzBunch.do_finish@ s r c $ | j y r )r r s r r z Bunch.closeC s r Nr )
ru rv rw rx r r r r r r rZ r r r r s& D8+ r r c e Zd Zd Zd Zy)
AppendTruec || _ y r )r# )rp r# s r r zAppendTrue.__init__H s r c : | j j d y rH )r# rX r s r r zAppendTrue.__call__J s r Nr rZ r r r r G s 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 y ) _TestBarrierz$
Tests for Barrier objects.
r g >@c \ | j | j | j | _ y )Nr )Barrierrx defaultTimeoutbarrierr s r setUpz_TestBarrier.setUpU s ||DFFD4G4G|H r c F | j j d | _ y r )r abortr s r tearDownz_TestBarrier.tearDownX s r c | j dk( rg S | j dk( r| j j S t S )Nr r )r r r r r s r r z_TestBarrier.DummyList\ s: 99 !I
YY)
#<<$$& & < r c t | ||| j dz
} || |j |j y # |j w xY wr )r rx r r )rp r rQ r s r run_threadsz_TestBarrier.run_threadsd sE $4 *
tH
!
GGIAGGIs A Ac |j }t | D ]J }|d j d |j |d j d |j L y # t $ r Y y w xY w)Nr Tr )partiesrS rX r r )r r resultsr mrV s r multipassz_TestBarrier.multipassl sk OOq A AJ d # LLN AJ d # LLN
" s & A21A2c | j | j g}| j | j | j ||f y)z;
Test that a barrier is passed in lockstep
N)r r r r )rp passesr s r test_barrierz_TestBarrier.test_barrier} s; >>#T^^%56 $,,)HIr c $ | j d S )zC
Test that a barrier works for 10 consecutive runs
r6 )r r s r test_barrier_10z _TestBarrier.test_barrier_10 s $$r c F |j }|j | y r )r r )r r r" r s r _test_wait_return_fz _TestBarrier._test_wait_return_f s lln
#r c 6 | j }| j | j | j |f t | j
D cg c] }|j
}}| j |j d d t | yc c}w )z9
test the return value from barrier.wait
r r N)
r r r r rS rx r rk countr# )rp r" rV r s r test_wait_returnz _TestBarrier.test_wait_return su
11DLL%3HI(-dff
61599;66 q)1-E 7s Bc L |j t | dk7 rt y r )r r r4 )r r r s r _test_action_fz_TestBarrier._test_action_f s" w<1 r c | j }| j | j t | }| j | j
||f | j
t | d y)z,
Test the 'action' callback
)r r N)r r rx r r r rk r )rp r r s r test_actionz_TestBarrier.test_action sZ ..",,tvvj.A,B ,,w.@A W q)r c |j }|| j dz k( rt |j |j d y # t j
$ r |j d Y y t $ r |j
Y y w xY wNr T)r rx r4 rX r BrokenBarrierErrorr )r r results1results2rV s r
_test_abort_fz_TestBarrier._test_abort_f sn ACEE1H}"" LLN OOD !++ " OOD ! MMO s A A $B
2B
B
c f | j }| j }| j | j | j ||f | j t | d | j t | | j dz
| j | j j y)zK
Test that an abort will put the barrier in a broken state
r r N) r r r r rk r rx r broken)rp r r s r
test_abortz_TestBarrier.test_abort s >>#>># ++ ,,(; = X * X q1 ++,r c |j }|| j dz k( r_|j | j dz
k r2t j d |j | j dz
k r2|j n" |j |j
d |j |j
d y # t j $ r |j
d Y Hw xY w)Nr r ru T) r rx n_waitingr r resetrX r r )r r r r results3rV s r
_test_reset_fz_TestBarrier._test_reset_f s LLN q=##ceeAg-
5! ##ceeAg- MMO
& % //
&%
&s !C $C-,C-c | j }| j }| j }| j | j | j |||f | j t | d | j t | | j dz
| j t | | j y)zL
Test that a 'reset' on a barrier frees the waiting threads
r r N)r r r r rk r rx )rp r r r s r
test_resetz_TestBarrier.test_reset s >>#>>#>># ++ ,,(HE G X * X q1 X /r c |j }|| j dz k( rt |j |j d |j | j dz k( r|j |j |j |j d y # t j
$ r |j d Y t $ r |j
Y w xY wr )r rx r4 rX r r r r )r r barrier2r r r rV s r _test_abort_and_reset_fz$_TestBarrier._test_abort_and_reset_f s ACEE1H}"" LLN OOD ! ==?ceeQh & MMO
++ " OOD ! MMO s A B- -$C.C.-C.c | j }| j }| j }| j | j }| j | j | j
||||f | j
t | d | j
t | | j dz
| j
t | | j y)zF
Test that a barrier can be reset after being broken.
r r N)r r rx r r# r rk r )rp r r r r" s r test_abort_and_resetz!_TestBarrier.test_abort_and_reset s >>#>>#>>#<<' 55 ,,(HhO Q X * X q1 X /r c |j }|| j dz k( rt j d |j d y # t j
$ r |j
d Y y w xY w)Nr ?r T)r rx r r r r rX r r r rV s r _test_timeout_fz _TestBarrier._test_timeout_f sY LLN q= JJsO ! LL ++ ! NN4 !s A $A21A2c | j }| j | j | j |f | j t | | j j y)z$
Test wait(timeout)
N)r r r) r rk r r )rp r s r r5 z_TestBarrier.test_timeout sM .." -- g/FG W t||';';<r c |j | j }|| j dz k( rt j d |j y # t
j $ r |j d Y y w xY w)Nr r' T)r r rx r r r r rX r( s r _test_default_timeout_fz$_TestBarrier._test_default_timeout_f s_ LL++ , q= JJsO ! LLN++ ! NN4 !s A $A<;A<c | j | j d }| j }| j | j ||f | j t
| |j y)z4
Test the barrier's default timeout
r r N)r rx r r r, rk r r )rp r r s r test_default_timeoutz!_TestBarrier.test_default_timeout# sY ,,tvvs,3.." 557IJ W w7r c f | j d }|j |j y r )r r )rp r s r test_single_threadz _TestBarrier.test_single_thread, s! LLO r c t | D ]. }|j |5 |j | d d d 0 y # 1 sw Y ;xY wr )rS r r )r r r connr_ rV s r _test_thousand_fz _TestBarrier._test_thousand_f1 sF v A LLN
!
s >A c 6 | j dk( r*| j dj | j d}| j }| j d \ }}t | j D ]X }| j | j | j |||f }|j | j |j Z t | D ]< }t | j D ]" }| j |j | $ > y )Nr r Fr )r r r rZ r rS rx r r3 r r rc r rk r )rp r r_ r2 r jr rV s r
test_thousandz_TestBarrier.test_thousand8 s 99 ! MM7>>tyyI Jyy{ 99U+jtvv $A D$9$9!% vz4 H JA
GGI OOAFF # $ v 1A466]
1 a0
1 1r Nr ) ru rv rw rx rx r r r r r r r r r r r r r r r r r r# r% r) r5 r, r. r0 r3 r7 rZ r r r r N s
ANI " " J%
*
- " 0 *
0 ! != ! !8
1r r c f e Zd ZdZddddd ed ed fgZd Zed
Zdd Z d Z
d
Z y)
_TestValuer )rV i i^ )dg
@g )hi )r r xyc 4 t s| j d y y Nz%requires multiprocessing.sharedctypesr r r s r r z_TestValue.setUpX MMA B r c T t || j D ] \ }}|d |_ y rq )zip codes_valuesr )r valuessvcvs r r z_TestValue._test\ s- &#"2"23 FB!uBH r c h |r2| j D cg c] \ }}}| j || }}}}n1| j D cg c] \ }}}| j || }}}}t || j D ]$ \ }}| j |j
|d & | j
| j |f }d|_ |j |j t || j D ]$ \ }}| j |j
|d & y c c}}}w c c}}}w )Nr r Tr ) rG RawValuer rF rk r r r r r r ) rp rawcoder r rH rI rJ r s r
test_valuez_TestValue.test_valueb s( ,0,=,=? ?($q mmD%0 ?F ? -1,=,=? ?($q jju- ?F ? &$"3"34 .FB RXXr!u - . ||4::VI|>
&$"3"34 .FB RXXr!u - . ??s D& D-c ( | j d y NT)rM )rO r s r
test_rawvaluez_TestValue.test_rawvalueu s D!r c | j dd }|j }|j }| j ddd }|j }|j }| j }| j dd| }|j } |j }
| j || | j ddd } | j t
| d | j t
| d | j t | j ddd | j dd } | j t
| d | j t
| d y )NrV r r_ Fget_lockget_objnavalue)
r rU rV rZ rk r r7 rl rD rL )
rp val1lock1obj1val2lock2obj2r_ val3lock3obj3arr4arr5s
r test_getobj_getlockz _TestValue.test_getobj_getlockx s, zz#q!
||~zz#qtz,
||~yy{zz#qtz,
||~ u%zz#quz- z23 y12 .$**c19M}}S!$ z23 y12r Nr ) ru rv rw r r rG r r r rO rR rc rZ r r r9 r9 L sW "M eCj%*%
LC
.&"3r r9 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 y)
_TestArrayr c ^ t dt | D ] }||xx ||dz
z
cc< y r )rS r )r seqrV s r r z _TestArray.f s2 q#c(# A Fc!A#h F r Nzrequires _ctypesc g d}|r| j d| }n| j d| }| j t | t | | j |d |d | j t |dd t |dd t j
dg d x|dd |dd | j t |d d | | j
| | j | j |f }d
|_ |j |j | j t |d d | y ) N)
i ir i i5 i$ i i i? rV r r r
)r r r ra ra r r T) RawArrayArrayrk r r arrayr r r r r )rp rM rg arrr s r
test_arrayz_TestArray.test_array s @ --S)C**S#&C S3s8, QQ( c!Ah c!Ah 8 #kk#| <<Aa3q8 c!f s+ s LLcVL 4 c!f s+r c 8 d}t d D ] }| j d| }| j t | | | j t | dg|z t d |d d | j t | t t d ~ y )Nr6 r rV r )rS rl rk r r )rp sizer rn s r test_array_from_sizez _TestArray.test_array_from_size s
q A**S$'C SXt , T#Yd
32YCF T#YU2Y 8
r c ( | j d y rQ )ro r s r
test_rawarrayz_TestArray.test_rawarray s D!r c | j dt t d }|j }|j }| j dt t d d }|j }|j }| j }| j dt t d | }|j } |j }
| j
|| | j dt d d } | j t | d | j t | d | j t | j dt d d | j dt d } | j t | d | j t | d y )NrV r6 rT FrU rV notalock) rl r rS rU rV rZ rk r r7 rl rD rk )
rp arr1rY rZ arr2r\ r] r_ arr3r_ r` ra rb s
r test_getobj_getlock_objz"_TestArray.test_getobj_getlock_obj sX zz#tE"I/
||~zz#tE"ITz:
||~yy{zz#tE"ITz:
||~ u%zz#uRyuz5 z23 y12 . **c59: G }}S%), z23 y12r r )
ru rv rw r r r rF ry r< ro rr rt rz rZ r r re re s "M X__Ud]$67, 8,0 X__Ud]$67 8 X__Ud]$67" 8" X__Ud]$673 83r re c @ e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d Z y
) _TestContainersr c | j t t d }| j |d d t t d | j }| j |d d g |j t t d | j |d d t t d | j |d d | j |dd g d |dz }| j |d d g d | j |ddgz g d | j |d d t t d ||g}| j | }| j |D cg c] }|d d c}g dg dg | j |g }|j d | j |d
d d g d y c c}w ) Nr6 r r )r r ra )
r r r r ra r r r r ra r ) r r r r ra r r r r ra r r )
r r r r ra r r r
r r r ) r r r r ra r r r
r r r )r rS rk extendrX )rp r r r: r elementr s r test_listz_TestContainers.test_list sz IId59o & 1tE"I/ IIK 1r" eAh 1tE!H~. 1q! 1R'* Q 1 => aV%IJ 1tE"I/
F IIaL '( )GWQZ )
+-K L
IIqcN 1a"IJ
*s & F>c F | j t t d }t | }| j t | t t d | j t | g t | }d|d< | j t | d y )Nr6 r) r )r rS r rk next)rp r its r test_list_iterz _TestContainers.test_list_iter sw IId59o &
!W b4b ?3 b2&
!W! b3'r c
| j t d D cg c] }| j t d c} }| j |D cg c] }|d d c}g dgdz d|d d< | j |d d d g d t dd D ] }| j || d d g d | j |d j d | j t |d d t ddd D ] }| j t || d " ~| j }|j | ~y c c}w c c}w ) Nr )r r r 7 r rA )r r r r r )r rS rk popr rX )rp _ir innerrV r s r test_list_proxy_in_listz'_TestContainers.test_list_proxy_in_list s, IIU1X>rtyyq*> ? 2u%(2YK!OD!R 1a*-q! 1A QqT!Wi 0 1
1Q' QqTA&q!Q +A S1Y * +
IIK
# ?2s !E Ec
B | j }t t dd }|D ] }t | ||< | j |j t d |D | j t
|j | | j t
|j |D cg c]
}t | c} | j t
|j |D cg c] }|t | f c} y c c}w c c}w )NA F c 3 6 K | ] }|t | f y wr )chr.0rV s r <genexpr>z,_TestContainers.test_dict.<locals>.<genexpr>+ s 'ECF 'Es )
dictr rS r rk r sortedkeysrH r )rp r: indicesrV s r test_dictz_TestContainers.test_dict& s IIKuR}% Aq6AaD 4'EW'E#EF )73
+g-Fc!f-FG *',JQaQ[,JK .G,Js ;D
;D
c f | j }t t dd }|D ] }t | ||< t | }| j t | | | j t | g t | }|j
| j t t | y )Nr r )
r r rS r r rk r rl r4 r )rp r: r rV r s r test_dict_iterz _TestContainers.test_dict_iter0 s IIKuR}% Aq6AaD
!W b7+ b2&
!W ,b1r c | j dd }| j dd }| j || }| j |d d | j |d d d d
|d d < | j |d d
| j |d d d
d |d d< | j |d d | j |d d d ~~| j |d
d d d|d d < | j |d d d |d
}|d }d |d< | j |d d | j |d d d |j | j t | d | j |d d | j |d d | j ||g }d|d d< | j |d d | j |d d d ~~| j |d d d | j ddg|g }| j |d t | j |d d d d y )Nr ra )ferretshamstersr6 r )waterfeed)petssuppliesr r r blanketsr
r r r r r marmotsX c rA r )r rk r r r r )rp r r r: louters r test_dict_proxy_nestedz&_TestContainers.test_dict_proxy_nested= sf yyQy/992A9. II4(I 3 '*B/ : w/4$%*
j! *-q1 : z2A6!"*
g '*A. : w/3 69-q1$&*
j! : z2B7yZ= '*A. : w/3 Q# '*A. j)1- IItX& '!Y i !, 1i !, 1i !, B8Q-( eAh- r2 v.2r c | j }|j | j |d j d | j |d j d | j
}| j |d< |d j d | j |d j d y )Nr { )r rX r r rk r r r s r test_nested_queuez!_TestContainers.test_nested_queuek s IIK !
1S) IIKzz|! !
1S)r c F | j }d|_ d|_ d|_ | j |j |j fd |`| j t | d | j
t |d | j
t |d y )NBobBuilderhidden)r r zNamespace(name='Bob')r+ job) Namespacer+ r _hiddenrk rn r r7 )rp r s r test_namespacez _TestContainers.test_namespaceu s NN !&&!%% *<=
E Q!89 6*+ GAu --.r N) ru rv rw r r r r r r r r r rZ r r r| r| s2 M K>((L 2,3\* /r r| c 6 t j | | | z S r r* )r? r s r sqrr s JJt Q3Jr c | |z S r rZ )r? r@ s r mulr Q3Jr c H t j | t ddz )Nr? i )r r rE r4 s r raise_large_valuerrorr s JJt
S7]
##r c | S r rZ r? s r identityr s Hr c e Zd ZdZd Zd Zy)
CountedObjectr c V | xj dz
c_ t j | S r ) n_instancesr< __new__r+ s r r zCountedObject.__new__ s 1 ~~c""r c @ t | xj dz c_ y r )r r r s r __del__zCountedObject.__del__ s T
!# r N)ru rv rw r r r rZ r r r r s K#$r r c e Zd Zy) SayWhenErrorNru rv rw rZ r r r r s r r c # t K |dk( r t d t | D ] }||k( r t d | y w)NrA zSomebody said when)r rS )totalwhenrV s r exception_throwing_generatorr sD rz/00
5\ 9 34 4s 68c 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 N t | | j d | _ y r` )super
setUpClassPoolpoolr __class__s r r z_TestPool.setUpClass s
88A;r c | j j | j j d | _ t | y r )r r r r
tearDownClassr s r r z_TestPool.tearDownClass s2
r c | j j }| j |t d t d | j |t dddi t d y )N)r r rZ r? r r )r applyrk r )rp papplys r
test_applyz_TestPool.test_apply sK T*CF3 R#a138<r c
| j j }| j |t t t d t t t t t d | j |t t t d d t t t t t d y )Nr6 r) r chunksize)r maprk r r rS )rp pmaps r test_mapz_TestPool.test_map s| yy}} c4b ?3T#c4b ?:S5TU c4c
#3rB c#tE#J'7 89 ;r c
| j j }t t t d t ddd }| j |t | t t j t | t t t d t ddd }| j |t |d t t j t | y )Nr6 r rA r) r r r )r starmapr rF rS rk r r )rp psmaptupless r test_starmapz_TestPool.test_starmap s !!c%)U1R_56 sF+ i / /V <= ?c%*eBr2&678 sFb9 i / /V <= ?r c
t t t d t ddd }| j | j j t | j t t j t | y )Nr) r rA )
r rF rS rk r
starmap_asyncr r r r )rp r s r test_starmap_asyncz _TestPool.test_starmap_async s_ c%*eBr2&678 00f=AAC i / /V <= ?r c
| j | j j t t t d j
t t t t t d y r| )rk r map_asyncr r rS r r r s r test_map_asyncz_TestPool.test_map_async sK ,,S$uRy/BFFH c#tE"I 78 :r c < | j dk( r| j j ng }| j j t
dg|j |j j | j dt | | j dg|d | j j t
dg|j |j j | j dt | | j |d t y )Nr 1)callbackerror_callbackr r r r ) r r r r r rI rX r rk r r rE )rp call_argss r test_map_async_callbacksz"_TestPool.test_map_async_callbacks s +/99 +ADLL%%'r C#%.%5%5+4+;+; ==ATV C N+ !il+ C#%.%5%5+4+;+; ==ATV C N+ ilJ7r c : | j dk( r*| j dj | j G d dt }| j t
5 | j j t | gdz d d d y # 1 sw Y y xY w)Nr r c e Zd Zd Zy)*_TestPool.test_map_unplicklable.<locals>.Ac t d )Nz
cannot pickler3 r s r r z5_TestPool.test_map_unplicklable.<locals>.A.__reduce__ s
"?33r Nr: rZ r r Ar s
4r r r6 ) r r r r< rl r4 r r r )rp r s r test_map_unplicklablez _TestPool.test_map_unplicklable su 99 ! MM7>>tyyI J 4 4
|
, ) IIMM#uRx ( ) ) )s *BBc | j j t g d j t y # t
j $ r | j d Y y w xY w)Nr r r z2pool.map_async with chunksize stalled on null list)r r r r r r TimeoutErrorri r s r test_map_chunksizez _TestPool.test_map_chunksize sS L II R1 5 9 9( 9 K ++ L IIJ K Ls 69 $A A c | j dk( r*| j dj | j | j t 5 | j
j
t t dd d d d d | j t 5 | j
j
t t dd d d d d | j t 5 | j
j
t t dd d d d d G d d }| j t 5 | j
j
t | d d d d | j t 5 | j
j
t | d d d d y # 1 sw Y /xY w# 1 sw Y xY w# 1 sw Y xY w# 1 sw Y sxY w# 1 sw Y y xY w) Nr r r rA r6 r c e Zd Zd Zd Zd Zy)E_TestPool.test_map_handle_iterable_exception.<locals>.SpecialIterablec | S r rZ 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 yr rZ r s r r zM_TestPool.test_map_handle_iterable_exception.<locals>.SpecialIterable.__len__
s r N)ru rv rw r r r rZ r r SpecialIterabler s
#
r r ) r r r rl r r r r r )rp r s r "test_map_handle_iterable_exceptionz,_TestPool.test_map_handle_iterable_exception s~ 99 ! MM7>>tyyI J
|
, G IIMM# ;Ar BA F G
|
, G IIMM# ;Ar BA F G
|
, G IIMM# ;B BA F G
|
, 5 IIMM# 0! 4 5
|
, 5 IIMM# 0! 4 5 5% G G G G G G 5 5 5 5s< ,F(,F5!,G4'G
8'G(F25F>G
GG"c | j j t dt f }t |j
}| j
| d | j |j t y )Nr
1 ) r apply_asyncr r r} r rk r r rp r r s r
test_asyncz_TestPool.test_async
sP ii##C!X 8CGG$ # $$S[[(;r c | j j t dt dz f }t |j
}| j
t j |t | j |j t y )Nr r' r ) r r
r r r} r rl r r r r r s r test_async_timeoutz _TestPool.test_async_timeout
s^ ii##C!X^)<=CGG$ /66XN $$S[[(;r c
| j j t t t d }| j t | t t
t t t d | j j t t t d }t d D ] }| j t | ||z " | j t |j | j j t t t d d }t d D ] }| j t | ||z " | j t |j y Nr6 r5 r) r ) r imapr r rS rk r r rl
StopIterationr rp r rV s r test_imapz_TestPool.test_imap
s
YY^^CeBi
1 b4CeBi (A#BC
YY^^CeBi
1r ,A T"Xqs + , -5
YY^^CeDk!2c^
Bt ,A T"Xqs + , -5r c x | j dk( r*| j dj | j | j j t
t
dd d }| j t |j | j j t
t
dd d }| j t |j | j j t
t
dd d }t d D ] }| j t | ||z " | j t |j | j j t
t
dd d }t d
D ] }| j t | ||z " | j t |j | j j t
t
dd d }t d D ] }| j t | ||z " | j t |j y ) Nr r r rA r6 r r r
r r ra )
r r r r r r r rl r r rS rk r r s r #test_imap_handle_iterable_exceptionz-_TestPool.test_imap_handle_iterable_exception#
s 99 ! MM7>>tyyI J YY^^C!=a!Da
H , 4
YY^^C!=a!Da
H , 4
YY^^C!=b!!Da
Hq ,A T"Xqs + , , 4 YY^^C!=b!!Da
Hq ,A T"Xqs + , , 4
YY^^C!=b!!Da
Hq ,A T"Xqs + , , 4r c
| j j t t t d }| j t
| t t t t t d | j j t t t d d }| j t
| t t t t t d y r )r imap_unorderedr r rS rk r r )rp r s r test_imap_unorderedz _TestPool.test_imap_unordered=
s
YY
%
%c4b ?
; T#c4b ?*C%DE
YY
%
%c4d +<
%
L T#c4d 3D*E%FGr c
| j dk( r*| j dj | j | j j t
t
dd d }| j t |j | j j t
t
dd d }| j t |j | j j t
t
dd d }t t t
t t d }| j t 5 t d D ]0 }t | }| j || |j | 2 d d d | j j t
t
dd d }t t t
t t d }| j t 5 t d D ]0 }t | }| j || |j | 2 d d d y # 1 sw Y xY w# 1 sw Y y xY w)
Nr r r rA r6 r r r
r )r r r r r r r rl r r r r rS r rm r )rp r expected_valuesrV r s r -test_imap_unordered_handle_iterable_exceptionz7_TestPool.test_imap_unordered_handle_iterable_exceptionD
s 99 ! MM7>>tyyI J YY
%
%c&B1b&I&')
, 4
YY
%
%c&B1b&I&')
, 4
YY
%
%c&B2q&I&') s3U2Y 89
|
, .2Y
. R
e_5 &&u-
. . YY
%
%c&B2q&I&') s3U2Y 89
|
, .2Y
. R
e_5 &&u-
. . . . . . .s ;?H7.?I7I I c | j dk( rt nt }| j || j d | j || j d | j dk7 rX| j d } | j dt
|j |j |j y y # |j |j w xY w)Nr rA r r )
r RemoteErrorrE rl r rk r _poolr r )rp expected_errorr s r test_make_poolz_TestPool.test_make_poolh
s )-i)?+ )
.$))R8 .$))Q7 99 ! ! A
CL1
"
s 7%B> >"C c L | j j t j t d D cg c] }d c}d }| j j t
| j j } | | j |j d y c c}w )Ni' r. r r r )
r r r r rS r r} r
assertLessr )rp rV rY r s r rB z_TestPool.test_terminatew
su $$ JJeEl33q %
TYY^^, c*
4s B!
c | j d }| j |j t g g | j t |j t g g | j t |j
t g g | j |j t g j g |j |j y r ) r rk r r r r r r r r r rO s r test_empty_iterablez _TestPool.test_empty_iterable
s IIaL sB , affS"o.3 a . .sB 78"= S"-113R8 r c | j dk( rt t d }|D cg c]
}t | }}| j d 5 }|j t | }| j
|j | d d d j | j t |j
t | y y c c}w # 1 sw Y FxY w)Nr r6 r ) r r rS r r r rk r r rl rE )rp LrV rZ r rs r test_contextz_TestPool.test_context
s 99 #U2YA()*1A*H*1
4KKQ' (3
4
FFH j!++sA > $*
4
4s C
7C Cc t d )Nr r3 r+ s r _test_tracebackz_TestPool._test_traceback
s
3 r c | j dk( r| j d 5 } |j | j | j d d d d j
| j t t | j |j d |j }| j t | t j j | j! d|j" t$ j& j) 5 } |y y # t
$ r }|}Y d }~d }~ww xY w# 1 sw Y xY w# t $ r' t+ j, t+ j. Y nw xY w d d d n # 1 sw Y nxY w| j! dj1 | j d 5 } |j3 t4 t7 dd d | j d n# t
$ r }|}Y d }~nd }~ww xY w| j t | t8 | j |j d d d d n # 1 sw Y nxY w|j
O)Nr r zexpected RuntimeError)r z&raise RuntimeError(123) # some commentrA zexpected SayWhenError) r r r r+ ri rh r ro r r4 rk rQ __cause__r r RemoteTracebackrm tbr= r r> rz
excepthookexc_infogetvaluer r r r )rp r r exccausef1s r test_tracebackz_TestPool.test_traceback
s 99 #1
77GGD 0 01 II 56
7
FFH MM$s)\ 2 SXXv .MME MM$u+';';'K'K L MMBEHH M --/
424 I# $ ! C
7
7" $ 4NNCLLN343
4
4
4
MMB ++-
) 1
37EE# ;Ar BAF II 56 ! C
d3i 6
cmmT2
3
3
3
FFHs D:D"D: F E" D7+D2-D:2D77D::E-E63F5E66FF I!G5#I5 H
>H IH
>IIc t d )NrS r3 r+ s r _test_wrapped_exceptionz!_TestPool._test_wrapped_exception
s
5!!r c | j d 5 }| j t 5 |j | j d d d d d d j y # 1 sw Y "xY w# 1 sw Y &xY wr )r rl r4 r r8 r rO s r test_wrapped_exceptionz _TestPool.test_wrapped_exception
sd
YYq\ 6Q""<0
6445
6 6
6
6 6 6s" A1 A%A1%A. *A11A:c , t j }| j t 5 | j d 5 } |j t ddg t j d |j |j d d d d d d | j t j |z
d y # t j d |j |j w xY w# 1 sw Y sxY w# 1 sw Y wxY w)Nr r r r g?) r r rl rE r r r r r r
assertGreater)rp t_startr s r test_map_no_failfastz _TestPool.test_map_no_failfast
s .."
z
* 1
EE/!Q8JJsOGGIFFH
4>>+g5s; JJsOGGIFFH
s9 D
C>C5C> D
7C;;C>>D D
Dc t d D cg c] }t }}|D cg c] }t j | }}| j j t | ~t j t j t | j t d |D d h | j t j d y c c}w c c}w )Nr6 c 3 * K | ] } |
y wr rZ )r rp s r r z3_TestPool.test_release_task_refs.<locals>.<genexpr>
s 1bRT 1s r )rS r rk rl r r r rm rn r r rN rk rd r )rp rV objsorefss r test_release_task_refsz _TestPool.test_release_task_refs
s */r3A
33(,-1 A--
h%
5 1D 11D6:
22A6 4-s
C Cc : | j dk( r| j d | j d }|5 d d d | j t 5 |5 d d d d d d |j y # 1 sw Y DxY w# 1 sw Y .xY w# 1 sw Y 2xY w)Nr test not applicable to managerr )r r r rl rE r rp r s r
test_enterz_TestPool.test_enter
s 99 ! MM: ;yy|
z
*
s/ A9BBB9BB
BBc p | j dk( r| j d | j d }|j |j t
j j |_ t j dt f 5 d }t j d d d y # 1 sw Y y xY w)Nr rF r z%unclosed running multiprocessing pool)r r r r r r r RUN_stater
check_warningsResourceWarningr
gc_collectrG s r test_resource_warningz _TestPool.test_resource_warning
s 99 ! MM: ;yy| &**..
+
+8/JL !D ! ! !s B,,B5)"ru rv rw r r r r r r r r r r r r r r r r r r r! rB r% r) r+ r6 r8 r: r> rD rH rO
__classcell__r s @r r r s =
; ??
: 8)L 54< < 6 54H".H
+
? $L " "<(
7 !r r c t d )Nkey)KeyErrorrZ r r raisingrU s
5/r c d S )Nc y)N* rZ rZ r r r z%unpickleable_result.<locals>.<lambda> r rZ rZ r r unpickleable_resultrZ s r c e Zd ZdZd Zd Zy)_TestPoolWorkerErrorsr c H t j d }d gfd}|j t | }| j t
|j | j d | j d t
|j |j y )Nr c | d< y r rZ r3
scratchpads r errbackz@_TestPoolWorkerErrors.test_async_error_callback.<locals>.errback s JqMr r r ) r r r
rU rl rT r r r r r )rp r ra r r` s @r test_async_error_callbackz/_TestPoolWorkerErrors.test_async_error_callback s} #V
mmGGm< (CGG,
1
& jmX6 r c ddl m} t j d }t d D ] }d gfd}|j t | }| j ||j d }| j | | j d | | j |j | j |j |j |j y )Nr )MaybeEncodingErrorr r c | d< y r rZ r_ s r ra z?_TestPoolWorkerErrors.test_unpickleable_result.<locals>.errback/ s #
1
r rb )multiprocessing.poolre r r rS r
rZ rl r r r assertIsNotNoner3 r r r )rp re r iterationra r wrappedr` s @r test_unpickleable_resultz._TestPoolWorkerErrors.test_unpickleable_result' s ; # r 0I J
$ -- 3G-LC 0#'' : mG OOG $ ! !*Q-1C D - / 0
r N)ru rv rw r rc rk rZ r r r\ r\ s #M
r r\ c ( e Zd ZdZd Zd Zd Zd Zy)_TestPoolWorkerLifetimer c t j dd }| j dt |j |j D cg c] }|j
}}g }t
d D ]( }|j |j t |f * t | D ]. \ }}| j |j t | 0 |j d}|rYt d |j D s=|dz }t j t |r t d |j D s=|j D cg c] }|j
} }| j# d | | j# d | | j% t' | t' | |j) |j+ y c c}w c c}w )Nr r6 maxtasksperchildr) 2 c 3 < K | ] }|j y wr r )r r s r r zD_TestPoolWorkerLifetime.test_pool_worker_lifetime.<locals>.<genexpr>Q s #BQAJJL#B r )r r rk r r r rS rX r
r enumerater _repopulate_poolallr r rN r r" r r r )
rp r r origworkerpidsr rV r6 r countdownfinalworkerpidss
r test_pool_worker_lifetimez1_TestPoolWorkerLifetime.test_pool_worker_lifetime@ ss R 8 CL))*1A!%%11s 6A NN1==qe4 5 6 "'* 0HQ SWWYA / 0
#B!''#B B NI JJu #B!''#B B +,''2Q15522 ~. / F> 2F?4KL 1 2" 3s G
Gc \ t j dd }g }t d D ]) }|j |j t
|df + |j
|j t | D ]. \ }}| j |j t | 0 y )Nr r ro r g333333?) r r rS rX r
r r r ru rk r )rp r r rV r6 r s r %test_pool_worker_lifetime_early_closez=_TestPoolWorkerLifetime.test_pool_worker_lifetime_early_close] s
Q 7q 9A NN1==q#h7 8 9 !'* 0HQ SWWYA / 0r c dD ]7 }| j t 5 t j d| d d d 9 y # 1 sw Y DxY w)N)r rA r 12r ro )rl rE r r )rp r s r "test_pool_maxtasksperchild_invalidz:_TestPoolWorkerLifetime.test_pool_maxtasksperchild_invalidj sP ' @E"":.
@ $$Q?
@
@ @
@
@s >A c d}t j j j d| \ }}}| j |d y )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 )r= r r assert_python_okrk rp cmdrh outrq s r >test_worker_finalization_via_atexit_handler_of_multiprocessingzV_TestPoolWorkerLifetime.test_worker_finalization_via_atexit_handler_of_multiprocessingo s= ||11BB4M C Q r N)ru rv rw r r{ r} r r rZ r r rm rm = s #M: 0@
r rm ) BaseManager BaseProxyr c e Zd Zd Zd Zd Zy)FooBarc y)Nf()rZ r s r r zFooBar.f s r c t r )rE r s r gzFooBar.g s r c y)N_h()rZ r s r _hz FooBar._h s r N)ru rv rw r r r rZ r r r r s r r c # : K t d D ] } | | z y wr| )rS )rV s r bazr s"
2Y c s c e Zd ZdZd Zd Zy)
IteratorProxy)r c | S r rZ r s r r zIteratorProxy.__iter__ s r c $ | j d S )Nr ) _callmethodr s r r zIteratorProxy.__next__ s
++r N)ru rv rw _exposed_r r rZ r r r r s I,r r c e Zd Zy) MyManagerNr rZ r r r r s r r Foo)callableBar)r r )r exposedr )r proxytypec ( e Zd ZdZd Zd Zd Zd Zy)_TestMyManagerr} c t t }|j | j | |j | j |j j dt j f y N)shutdown_timeoutr )
r SHUTDOWN_TIMEOUTr commonshutdownrm _processr r8 r@ rp r s r test_mymanagerz _TestMyManager.test_mymanager sU -=>
G
g&&//!fnn_1EFr c t t }|5 | j | d d d | j |j j
dt j f y # 1 sw Y AxY wr )r r r rm r r r8 r@ r s r test_mymanager_contextz%_TestMyManager.test_mymanager_context sX -=>
! KK !
g&&//!fnn_1EF ! !s A%%A.c t t }|j |5 | j | d d d | j |j
j d y # 1 sw Y 0xY wr )r r r r rk r r r s r !test_mymanager_context_prestartedz0_TestMyManager.test_mymanager_context_prestarted sV -=>
! KK ! ))22A6 ! !s A$$A-c |j }|j }|j }dD cg c] }t || s| }}dD cg c] }t || s| }}| j |ddg | j |ddg | j |j d | j
t |j | j |j d d | j
t |j d | j |j d | j |j d | j |j d d | j |j d d | j t | t d D cg c] }||z c} y c c}w c c}w c c}w )N)r r r r r r r r r6 )r r r r7 rk r rl rE r r r r r rS ) rp r rS barr r+ foo_methods bar_methodsrV s r r z_TestMyManager.common so kkmkkmkkm(8OGC<NtO O(8OGC<NtO O sCj1 sDk2 %( *cee, -u5 +s= %( 6* -u5 .7 c%)$<QQqS$<=! PO %=s G G G#G7 G
N)ru rv rw r r r r r rZ r r r r s M GG7>r r c t S r )_queuerZ r r get_queuer s Mr c e Zd ZdZy) QueueManagerz$manager class used by server processNru rv rw rx rZ r r r r s .r r r c e Zd ZdZy)
QueueManager2z@manager class which specifies the same interface as QueueManagerNr rZ r r r r s Jr r xmlrpclibc 8 e Zd ZdZg dZedd Zed Zd Zy)_TestRemoteManagerr} ) hello worldNT @u hallå världenu привіт світs
hall vrldenNc t ||t t }|j |j }|j t
| j y )Nr r
serializerr )r
SERIALIZERr connectr r r rH 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 | j | j |j |f }d|_
|j t |j |t
t }|j |j! }| j# |j% | j& | j) t* |j, t. j0 ~y )N r r r T)rB urandomr r HOSTr r r rc r r r r r r r r rk r rY rl rh r r r )rp r r r manager2r" s r test_remotez _TestRemoteManager.test_remote s **R. "''+W -/
(() LL GOOW3ML N OOW -/ ""$ dkk2
)UYY
;
r ) ru rv rw r rH rY r r r rZ r r r r s0 MF
AYF% %r r sha256c " e Zd Zed Zd Zy)_TestManagerRestartc t ||t t }|j |j }|j d y )Nr r )r r r r r r r s r r z_TestManagerRestart._putter s< W -/ !!#
- r c t j d }t t j df|t
t } |j }|j }|j j |j | j | j |j |f }|j |j |j }| j! |j# d ~t% |d r|j' t ||t
t } |j | j) |j& y # t% |d r|j' w w xY w# t* $ r}|j, t, j. k7 r t1 j2 d t ||t
t }t% |d r | j) |j& Y d }~y Y d }~y d }~ww xY w)Nr r r r r r r' )rB r r r r r r
get_serverr listenerr r r r r r rk r r7 r rc OSErrorerrno
EADDRINUSEr r )rp r r srvraddrr r" r s r test_rapid_restartz&_TestManagerRestart.test_rapid_restart) s **R. "''+W!4DF #%%'D<<D
MM ! MMO DLL7Q RA
GGI
FFH%%'E UYY[- 8w
+ " 'j -/
2 MMO OOG , , - w
+ " ,
2ww%***
JJsO" g*!13G w
+ 0 011 ,
2s% C E 3+F E> H
A1HH
N)ru rv rw r r r rZ r r r r s ! !'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 ed
k d e j eed d d Zed Z e j ed e j ej$ d k( d d Zd Zy)_TestConnectionr c t |j t D ] }|j | |j y r )r
recv_bytesSENTINEL
send_bytesr )r r2 msgs r _echoz_TestConnection._echo\ s1 2 !C OOC !
r c | j \ }}| j | j |f }d|_ |j g d}t d }|dz }t
j dt t d }| j dk( r-| j t |j t | j |j | d | j |j | | j |j! | d | j |j# | | j dk( rt
j dd gdz }t | d gdt% | z
z z } | j |j! | d | j |j' | t% | |j( z | j t | | t
j dd gdz }d gd
z t | z d gd t% | z
z z } | j |j! | d | j |j' |d
|j( z t% | |j( z | j t | | t+ t d }| j |j! | d |j' | }
| j- d
|
z t5 |j6 } | j | d | j9 | j: d | j | d d | j9 | j: d | j | t< d | j9 | j: t< |j d t? j@ d | j | t< d | j9 | j: d | j |j d t d dz }
|j! |
| j |j# |
|j! tB |jE | j dk( rx| j |jF d | j |jH d | jK tL |j | jK tL |j" |jO y # t. j0 $ r(} | j | j2 |f Y d } ~ hd } ~ ww xY w)Nr T)r r Nr r6 rV ra r r r r
z( z expected BufferTooShort, got %sFrA r. Xi )(r r r r r r rm r rS r rk r filenorI r r r r r recv_bytes_intoitemsize bytearrayri r BufferTooShortrQ r} r r r r r r r r readablewritablerl EOFErrorr )rp r2 r r rg r longmsgrn bufferrZ r r r really_big_msgs r test_connectionz _TestConnection.test_connectionb s2 99;j LL
* L ? M"(kk#tE!H~. 99 # T$++- 0# 6 3 . c* -t4 *C0 99 #[[qc"f-FCyA3"s3x-#88H T__S 14 8 T 1 1& 9 X 7
9 T&\8 4[[qc"f-FsQwc*aSFSX4E-FFH T__S 14 8 T 1 1&!foo:M N X 7
9 T&\8 4 uX/F T__W 5t <
C**62 ;cAB TYY' ' $$T\\15 b5) $$T\\15 h / $$T\\8< $
2 h . $$T\\15 d+ s'78 ' *N; ! 99 # T]]D 1 T]]D 1 h 2 h 8 K #11
5 '44
5s 4U V VVc r | j d \ }}| j |j d d | j |j d | j dk( r| j |j
d | j |j d | j |j
d | j |j d | j t |j d | j t |j | j t |j y y )NFr r r Tr )
r rk r r r r r rl r r )rp readerwriters r test_duplex_falsez!_TestConnection.test_duplex_false s %0 Q . * 99 # V__d 3 V__e 4 V__e 4 V__d 3 gv{{A 6 gv{{ 3 gv{{ 3 $r c | j \ }}| j | j |f }d|_ |j |j t
d }|j | | j |j | |j t |j |j y )Nr Tr ) r r r r r r r r rk r r r )rp r2 r r r s r test_spawn_closez _TestConnection.test_spawn_close s 99;j LL
* L ? Gn *C0 !
r c 2 | j dk7 r*| j dj | j t d }| j \ }}|j | | j
|j | |j |d | j
|j |dd |j |dd | j
|j |dd |j |d | j
|j t d |j |dd
| j
|j t d | j t |j
|d | j t |j
|d d | j t |j
|dd
| j t |j
|d | j t |j
|dd y )Nr r abcdefghijklmnopqrstuvwxyzr r
r r r r rA ra )
r r r r r r rk r rl rE )rp r r r s r test_sendbytesz _TestConnection.test_sendbytes s 99 # MM7>>tyyI J01yy{1 S - S! QR1 S!Q Qs4 S" r3 S"a r3 *allC< *allCQ? *allCQ? *allC< *allCB?r c t j | y# t $ r(}|j t j k( rY d }~y d }~ww xY wrY )rB fstatr r EBADF)r r r s r _is_fd_assignedz _TestConnection._is_fd_assigned s? HHRL ww%++% s A AAA c j |rGt dd D ]8 }| j | rt j |j | : t j | }t r$t j |t j }t j || t j | y )Nr r9 ) rS r rB dup2r r recv_handlemsvcrtopen_osfhandler r, r )r r2 datacreate_dummy_fdsrV r s r _writefdz_TestConnection._writefd s 1c]
.**1-GGDKKM1-
.
"
"4
( &&r2;;7B
T
r $test needs multiprocessing.reductionc | j dk7 r| j d | j d \ }}| j | j |df }d|_ |j
| j t j t j t t j d 5 }|j }t rt j | }t j |||j" d d d |j% t t j d 5 }| j' |j) d d d d y # 1 sw Y ]xY w# 1 sw Y y xY w) Nr only makes sense with processesTr s foor wbrb)r r r r r r r rc r r r r r r
get_osfhandler send_handler r rk r )rp r2 r r r r s r test_fd_transferz _TestConnection.test_fd_transfer
s 99 # MM; < 99D91j LL
Z4HL I (()*:*:;
)""D
) 3QB))"- ! !$AEE 2 3
)""D
) /Q QVVXv . / /
3 3 / /s 4A
E 3!E) E&)E2r1 *test semantics don't make sense on Windowsr9 z)largest assignable fd number is too smallr ztest needs os.dup2()c | j dk7 r| j d | j d \ }}| j | j |ddf }d|_ |j
| j t j t j t t j d 5 }|j }t dt D ] }| j | r n | j! d t# j$ | t' j( |||j* t# j, | d d d |j/ t t j d
5 }| j1 |j3 d d d d y # t# j, | w xY w# 1 sw Y wxY w# 1 sw Y y xY w) Nr r Tr s barr r r9 z2could not find an unassigned large file descriptorr )r r r r r r r rc r r r r r rS MAXFDr ri rB r r r r r r rk r )rp r2 r r r r newfds r test_large_fd_transferz&_TestConnection.test_large_fd_transfer
ss 99 # MM; < 99D91j LL
Z4NL O (()*:*:;
)""D
) QB sE*
P++E2
P NO GGB
%%dE1559
)""D
) /Q QVVXv . / / / /s6 55G+*G!F)7G?!G)G GG Gc L t j |j d y )N )rB r, r rp r2 s r _send_data_without_fdz%_TestConnection._send_data_without_fd>
s
&r z doesn't make sense on Windowsc B | j dk7 r| j d | j d \ }}| j | j |f }d|_ |j
| j t t j | |j y )Nr r Tr r ) r r r r r r r rl r4 r r r rp r2 r r s r test_missing_fd_transferz(_TestConnection.test_missing_fd_transferB
s}
99 # MM; < 99D91j LL : :* L O , (=(=tD r c ~ | j \ }}|5 |5 |j d | j |j d | j dk( r6| j |j | j |j d d d d d d | j dk( rw| j |j | j |j | j t |j | j t |j y y # 1 sw Y xY w# 1 sw Y xY wN r )
r r rk r r r closedr rl r r s r r) z _TestConnection.test_contextQ
s yy{1
+ +
FF4L QVVXt ,yyK' * * + + 99 # OOAHH % OOAHH % gqvv . gqvv . $ + + + +s# D3A7D'D3'D0 ,D33D<Nr )ru rv rw r r r r r r r r r rF r
HAS_REDUCTIONr ry rz r{ r r7 rB r r r r) rZ r r r r X sc ,M
M^ 4* @@ X (NO/ P/$ X (NOX__S\\W,ACX__Uc\@BXV,/1/1BC P/4 ' ' X (NOX__S\\W,.MN O P /r r c b e Zd ZdZd Zd Z ej ej d d Z
y)
_TestListenerr c | j j D ]o }| j j | }| j |j | j t | j j |j | q y )Nfamily)
connectionfamiliesListenerrc r rl r r )rp r) r s r test_multiple_bindz _TestListener.test_multiple_binde
sg oo.. 1F(((7A OOAGG $ gt'?'? ii
1 1r c | j j 5 }| j j |j 5 }|j 5 }|j d | j
|j d d d d d d d d d d | j dk( r!| j t j y y # 1 sw Y JxY w# 1 sw Y NxY w# 1 sw Y RxY wr! r* r, Clientr acceptr rk r r rl r )rp r r r: s r r) z_TestListener.test_contextl
s
__
%
%
' 51 '' 2
5aXXZ 51FF4L$$QVVXt45
5 5 99 # gqxx 0 $ 5 5
5
5 5 5s; &C%C2C
C C%
C CC" C%%C.z"test needs abstract socket supportc | j j d 5 }| j j |j 5 }|j 5 }|j d | j
|j d d d d d d d d d d | j dk( r!| j t j y y # 1 sw Y JxY w# 1 sw Y NxY w# 1 sw Y RxY w)Nz
somethingr" r r/ )rp r clientr: s r test_abstract_socketz"_TestListener.test_abstract_socketv
s __
%
%m
4 5 ''(8(89
5V __& 5!KK%$$QVVXt45
5 5 99 # gx 7 $ 5 5
5
5 5 5s; &C&C2CC
C&C CC# C&&C/N) ru rv rw r r- r) rF r r abstract_sockets_supportedr4 rZ r r r& r& a
s= "M11 X88=?8?8r r& c 2 e Zd ZdZed Zd Zd Zd Zy)_TestListenerClientr c | | j j | }|j d |j y )Nr )r* r0 r r )r r r2 s r r z_TestListenerClient._test
s+ ~~$$W- '
r c | j j D ] }| j j | }| j | j |j
f }d|_ |j |j }| j |j d |j |j y )Nr( r Tr )
r* r+ r, r r r r r r1 rk r r r )rp r) r r r2 s r test_listener_clientz(_TestListenerClient.test_listener_client
s oo.. F(((7A DJJaii\ BAAH
GGI88:D TYY[' 2
FFH
GGI r c | j j }| j | j |j f }d|_ |j
t j d |j }| j |j d |j |j |j y )Nr Tr r )r* r, r r r r r r r r1 rk r r r )rp r r r2 s r test_issue14725z#_TestListenerClient.test_issue14725
s OO $ $ & LL
!)) L >
1
xxz g.
r c | j j D ] }| j j | }| j j |j }|j }|j
d | j |j d |j |j |j y )Nr( hellor )
r* r+ r, r0 r r1 r r r r )rp famr r r s r test_issue16955z#_TestListenerClient.test_issue16955
s ??++ C(((4A&&qyy1A
A
LL " OOAFF1I &
GGI
GGI
GGI r N) ru rv rw r r r r: r< r@ rZ r r r7 r7
s( ,M
r r7 c X e Zd ZdZd Zed Zd Zed Zd Z ed Z
d Z y )
_TestPollr c | j \ }}| j |j d |j d | j |j d | j |j d y )NFr T)r rk 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 |j | * |j y Nr. )r r r r )r r2 stringsr s r _child_stringsz_TestPoll._child_strings
s3 A JJsO OOA
r c D d}| j \ }}| j | j ||f }|j |D ]G }t d D ] }|j d s n |j
}| j || I |j y )N)r> r a br s byer s lopr rt ) r r rH r rS r r rk r )rp rG r r r r rV r? s r test_stringsz_TestPoll.test_strings
s Gyy{1 LL 3 31g,L G #A3Z
66$<
A Q " #
r c & |j d y r )r )r r( s r _child_boundariesz_TestPoll._child_boundaries
s
q r c j | j d \ }}| j | j |f }|j t j
d ddg}|D ] }|j
| |j |j | j |j | y )NFr r s firsts second) r r rO r r r r r r rm r )rp r( r r r' r# s r test_boundariesz_TestPoll.test_boundaries
s yy 1 LL 6 6aTL B
1
y ! C
LL
allna(r c j |j d |j d |j d y )NrJ rK cd)r )r r s r _child_dont_mergez_TestPoll._child_dont_merge
s& T T Ur c 4 | j \ }}| j |j d d | j |j d d | j | j |f }|j | j |j
d | j |j d d | j |j d d | j |j
d | j |j d d | j |j d d | j |j d d | j |j
d |j y )
Nr3 Fr. r rJ r' TrK rS )r rk r r rT r r r )rp r r r s r test_dont_mergez_TestPoll.test_dont_merge
s' yy{1 e, e, LL 6 6aTL B . d+ d+ . d+ d+ d+ / r N) ru rv rw r rD r rH rM rO rQ rT rV rZ r r rB rB
sW ,M)
)
r rB r c \ e Zd ZdZed Zed Zed Zd Zed Z d Z
y) _TestPicklingConnectionsr c P ddl m} |j t j y )Nr )resource_sharerr )r rZ r r r )r rZ s r r z&_TestPicklingConnections.tearDownClass s 3 W%9%9 :r c 2 |D ]z }| j j | }|j |j |j }|j | |j |j | t
j t j df }|j |j |j \ }}|j | |j |j |j y )Nr( r ) r* r, r r r1 r socket
create_serverr r getsocknamer )r r2 r+ r? r new_connr s r _listenerz"_TestPicklingConnections._listener s C''s'3A IIaii xxzH IIh NN
GGI
-"4"4a!8 9 !--/"$ ( r c t |j d D ]O \ }}| j j | }|j |j |j
Q |j \ }}t j }|j | |j |j |j
|j
y r )
r r r* r0 r r r r\ r sendall)r r2 r r r3 s r _remotez _TestPicklingConnections._remote# s "499d 3 NWc^^**73F KK $ LLN
yy{ w syy{#
r c | j j }| j \ }}| j | j ||f }d|_ |j
|j | j \ }}| j | j |f }d|_ |j
|j |D ]w }d|z j d } |j }
|j |
| f |j } | j | j | j y |j d t d } |j }
|j |
| f |j } g } | j d }
|
sn| j |
&dj! | } | j | | j | j |j d |j |j |j! |j! y )Nr Tz This connection uses family %sasciiz$This connection uses a normal socketr) r )r* r+ r r r` r r r rc r r r rk r r rX r )rp r+ lconnlconn0lpr rconn0rpr? r r r_ bufr s r
test_picklingz&_TestPicklingConnections.test_pickling2 s ??++
v
\\ vx6H\
I
v
\\ VI\
>
;C3c9AA'JCjjlG JJ~ & zz|H X]]_ciik : ;
4:;**,
GS>"::<
c"A JJqM
hhsm ciik*
4
r c |j }|j d |j |j }|j }|j |dz |j y )N all is wellr )r r r )r r2 r r( r s r child_accessz%_TestPicklingConnections.child_access` sQ IIK } IIKffh #a%
r c | j \ }}| j | j |f }d|_ |j |j | j d \ }}|j
| |j | j |j d |j | j d \ }}|j
| |j |j
d |j | j |j d |j y )Nr TFr rn foobar foobarfoobar)
r r ro r r r r rk r r )rp r2 r r r( r s r test_accessz$_TestPicklingConnections.test_accessl s 99;j LL 1 1
L F yyy&1 ! =1 yyy&1 ! x j1 r N) ru rv rw r r r r` rc rl ro rs rZ r r rX rX sb #M; ; $ ,\ r rX c 8 e Zd ZdZ fdZ fdZd Zd Z xZS ) _TestHeapr c t | t j j j
| _ t j j t j j _ y r )r r r r r _heapold_heapHeaprp r s r r z_TestHeap.setUp sH
',,::@@
3B3G3G3L3L3N **0r c t | j t j j _ t
| y r )rx r r r rw r r rz 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 j | }|j | t | |kD rt j | }||= ~} |j 5 g }d} d}
t |j j D ]G } | D ]@ \ } }
}|j |j j# | |
|||
z
df | ||
z
z
} B I |j$ j' D ]I \ } }|D ]? \ }
}|j |j j# | |
|||
z
df |
||
z
z
}
A K | j) | |
z t+ d |j D |j- t t | dz
D ]p }|| d d \ } }
}||dz d d \ }}}| |k7 r<| j) ||j | j. | j) |d _| j) || r d d d t j0 | |r|j3 |r| j) |j4 |j6 | j) t |j8 d | j) t |j d | j) t |j$ d|j$ | j) t |j d y # 1 sw Y xY w)
N rq r r r5 freeoccupiedc 3 4 K | ] }|j y wr rq )r arenas r r z&_TestHeap.test_heap.<locals>.<genexpr> s F Fs r ) r r r rw _DISCARD_FREE_SPACE_LARGER_THANrS rI randomlognormvariaterX r randranger r _len_to_seqrH _arenasindex_allocated_blocksr rk sumsortrq shuffler _n_frees
_n_mallocs_pending_free_blocks)rp
iterations maxblocksblocksr rV rq r rw r~ r r' r r r arena_blocksnarenanstartnstops r test_heapz_TestHeap.test_heap s9
##1177/0, z" Av,,Q2T9:D $$2248A MM! 6{Y&$$Y/1I ZZ 3CDH$**1134
)*+ )&E5$JJ 2 25 95$ $U
F 4 5T%Z(D)
) (,'='='C'C'E
-#|#/ -KE4JJ 2 25 95$ $U
J 8 9 e,H-
-
TH_ F F F
H
HHJ3s8A:&
3'*1vbqz$t*-ac(2A,'F?$$T4<<+>+C+CD$$VQ/ $$T62
3- 3D v JJL
8 T 6 67; T\\*A. T 3 34a9O9OP T - -.2U 3 3s
F#M##M,c t j s3t j | j t j t j
} | j t j g| t j d t d D ]N }t j j d }t j j d }||_ ||_ P y )Nr6 r} r ) rm isenabledenablerc disable
get_threshold
set_thresholdrS r r r buddy)rp
thresholdsrV r r s r test_free_from_gcz_TestHeap.test_free_from_gc s ||~ IIK OOBJJ '%%'
((6:6
t A $$2215A $$2215AAGAG r ) ru rv rw r r r r r rP rQ s @r ru ru s "MO >3@r ru c " e Zd ZdefdefdefgZy)_Foor? r@ zN)ru rv rw r< r= r> _fields_rZ r r r r s e h j
Hr r c : e Zd ZdZd Zed ZddZd Zd Z y) _TestSharedCTypesr c 4 t s| j d y y rB rC r s r r z_TestSharedCTypes.setUp rD r c L |xj dz c_ |xj dz c_ |xj dz c_ |xj dz c_ |xj dz c_ |xj dz c_ t t | D ] }||xx dz cc< y rq )r r? r@ rS r )r r? r@ r rS rn stringrV s r _doublez_TestSharedCTypes._double su 1 1 1
s3x A FaKF r c h t dd| }t t d| }t t d| }t t dd| }| j dt t
d | }| j d
d | }t d |_ | j | j ||||||f
}d|_ |j |j | j |j d | j |j d | j |j d | j |j d | j |j" d t
d D ] } | j || | dz | j |j t d y )NrV r
rT gUUUUUU?r= r r r: r6 r r r r T gUUUUUU?r> r @
hellohello)r r= r> r rl r rS r r r r r r r rk r r? r@ )
rp r_ r? r@ r rS rn r r rV s
r test_sharedctypesz#_TestSharedCTypes.test_sharedctypes s[ #qt $ (G$ / *gD 1D!QT*jjd59oDj9C$/ W~ LL Aq!S#v3NL O "% qww0 '* " suuc*r 0A " "3q61Q3 / 0 u\':;r c ( | j d y )NTrT )r r s r test_synchronizez"_TestSharedCTypes.test_synchronize& s D )r c t ddd }t | }d|_ d|_ d|_ | j |j d | j
|j d | j |j d y )Nr r/ r= r )r r r? r@ r rk r )rp rS r s r test_copyz_TestSharedCTypes.test_copy) sj 1c7#3i " suuc* (r Nr )
ru rv rw r r r r r r r rZ r r r r s0 "MC <.*)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
k7 d d Z e
j ej d
k7 d
d Zd Zd Zd Zd Zd Zy)_TestSharedMemoryr c t | t rt j | }n| }||j d t | |j
y r )r rn r SharedMemoryrk r r )shmem_name_or_obj binary_data local_smss r !_attach_existing_shmem_then_writez3_TestSharedMemory._attach_existing_shmem_then_write: sC ' -%223DEI)I+6
's;'(r c B |t t j z S r )rn rB r )rp prefixs r
_new_shm_namez _TestSharedMemory._new_shm_nameC s BIIK(((r c
| j d }t j |dd }| j |j | j |j | | j |j d | j t |j |j | j |j t | | j t |j t | d|j d< | j |j d d t j | }| j |j d d |j t j |d|j z }| j |j d|j z |j | j t 5 t j dd d d d | j t 5 t j d
d d d t" j$ j' d 5 }t j( }| j d
| j d g}|D cg c] }||z }}||_ t j dd } | j | j | j | j, |d ||_ t j dd }
| j |
j | j |
j, |d d d d t j. r| j d } t j | dd } | j t0 5 | j | j d t j | }
|
j |
j | j | j d d d | j t2 5 t j |dd }d d d t j. rW G d dt j } || }| j |j |j |j | j t0 5 t j d }|j d d d |j y # 1 sw Y xY w# 1 sw Y xY wc c}w # 1 sw Y xY w# | j w xY w# 1 sw Y <xY w# 1 sw Y xY w# 1 sw Y uxY w)N test01_tsmbT createrq rX r r r Fr ,multiprocessing.shared_memory._make_filename test01_fn test02_fnr test01_dblunlinkr} c > e Zd Zej ej
z Zy)O_TestSharedMemory.test_shared_memory_basics.<locals>.OptionalAttachSharedMemoryN)ru rv rw rB r O_RDWR_flagsrZ r r OptionalAttachSharedMemoryr s bii/r r test01_notthere)r r r rc r rk r+ r3 rq r rk rm rn r r# rl rE rF mockpatch_SHM_NAME_PREFIX side_effect_name
_USE_POSIXFileNotFoundErrorFileExistsError)rp name_tsmbsmsalso_smssame_smsmock_make_filename NAME_PREFIXnamesr+ shm1shm2name_dblunlinksms_unosms_duothere_can_only_be_one_smsr ok_if_exists_smsnonexisting_smss r test_shared_memory_basicsz+_TestSharedMemory.test_shared_memory_basicsI sJ &&}5 ((4cJ
#
9- #. CGG chh7
chhC)
c#((mSX.
R( !--i8 a "- !--ibkJ
r#(({3
z
* = & &d < =
z
* 5 & &e 4 5
]]
:< 3?Q'88K'' 4d6H6H6UVE 5::D[4':E:-2 * --TBD OODKK ( TZZq 2-2 * --TBD OODKK ( TZZq 2# 3& # # " / /0B CN#00 G
""#45
% %++GLL$? + 8 8 HGNN$MMOMMO NN$
%
/ )6(B(B) % # #
0]-G-G
0 9) D - 2 2CHH = " " $
0
1 % + 8 89J KO " " $ % c = = 5 5 ; 3 3T NN$
%
% 0 % %st #TT7T-
T(B2T-!U#A!T:U2U &U)TT%(T--T7:U UU U&)U2c ^ t j j d 5 }t j }| j d | j d g}|D cg c] }||z }}||_ t j dd }| j |j | j |j |d ||_ t j dd }| j |j | j |j |d d d d y c c}w # 1 sw Y y xY w)Nr test03_fn test04_fnTr r r ) rF r r r r r r r rc r rk r )rp r r r r+ r r s r test_shared_memory_recreatez-_TestSharedMemory.test_shared_memory_recreate s ]]
:< 3?Q'88K'' 4d6H6H6UVE 5::D[4':E:-2 * --TBD OODKK ( TZZq 2-2 * --TBD OODKK ( TZZq 2# 3 3 ; 3 3s 7D# D #B2D# D##D,c | j t 5 t j dd }d d d | j t 5 t j dd }d d d | j t 5 t j d }d d d y # 1 sw Y sxY w# 1 sw Y JxY w# 1 sw Y y xY w)NTrA r r r )rl rE r r )rp sms_invalids r "test_invalid_shared_memory_crationz4_TestSharedMemory.test_invalid_shared_memory_cration s
z
* K'44DrJK K
z
* J'44DqIK J
z
* B'44DAK B B K K J J B Bs# B B, B8 B),B58Cc t t j dz D ] }| j | 5 t j
dd }| j
|j d|j dd t j || }t j | }| j |t j
| j |j |j | j t |j dd d | j t |j dd d d
|j dd | j t |j dd d
| j t |j dd d
d |j dd | j t |j dd d | j t |j dd d d d d y # 1 sw Y xY w) Nr protoTr r pickler r protocols newvals oldval)rS pickleHIGHEST_PROTOCOLr r r rc r rk dumpsloadsr rk r+ r )rp r r pickled_smssms2s r "test_shared_memory_pickle_unpicklez4_TestSharedMemory.test_shared_memory_pickle_unpickle s 622Q67 BE E *
B#003G
+ (! %ll3 ? ||K0%%dM,F,FG 4995 swwq|!4i@ txx!}!5yA )! swwq|!4i@ txx!}!5yA )1
swwq|!4i@ txx!}!5yA-
B
B B
B
Bs GHH c t t j dz D ] }| j | 5 t j
dd }d|j dd t j || }|j |j | j t 5 t j | d d d d d d y # 1 sw Y xY w# 1 sw Y xY w)
Nr r Tr r r r r r )
rS r r r r r rk r r r rl r r )rp r r r s r .test_shared_memory_pickle_unpickle_dead_objectz@_TestSharedMemory.test_shared_memory_pickle_unpickle_dead_object s 622Q67 .E E *
.#003G (! $ll3 ?
&&'89 .LL-.
.
. .. .
.
.s$ A3C%C;CC CC# c T t j dd }| j |j | j | j
|j df }d|_ |j |j | j t |j d d d | j | j
|df }d|_ |j |j | j t |j d d d |j y )NTr r s howdyr r s HELLO)r r rc r r r r+ r r r rk r rk r )rp r r s r #test_shared_memory_across_processesz5_TestSharedMemory.test_shared_memory_across_processes s ((3?
#
LL99((H%
swwr{+X6
LL99x
swwr{+X6 r r' z#not feasible in non-posix platformsc t j j }|j |j t d }t
j |j j t j |j t d }| j t 5 t
j t
j t j d d d |j y # 1 sw Y xY wr| )r managersSharedMemoryManagerr
ShareableListrS rB rD r r r8 r rl r r r )rp smmslsl2s r 4test_shared_memory_SharedMemoryServer_ignores_sigintzF_TestSharedMemory.test_shared_memory_SharedMemoryServer_ignores_sigint! s &&::<
uRy
)
&--0 b *
0
1 0 GGBIIK / 0 0 0s 07D D z resource_tracker is posix onlyc d}t j j j d| \ }}}| j | y )Nzif 1:
from multiprocessing.managers import SharedMemoryManager
smm = SharedMemoryManager()
smm.start()
sl = smm.ShareableList(range(10))
smm.shutdown()
r )r= r r r r r s r >test_shared_memory_SharedMemoryManager_reuses_resource_trackerzP_TestSharedMemory.test_shared_memory_SharedMemoryManager_reuses_resource_tracker9 s= ||11BB4M C
r c ( t j j }| j t 5 |j d d d d |j
t dd D cg c] }|j t | }}t ddd D cg c] }|j | }}t j |d j j }| j t | d t j
|d j }| j t |j d |d j }|j! t" j$ d
k7 r4| j t& 5 t j
| } d d d t j j 5 }
|
j d } |
j d } | j j }d d d t" j$ d
k7 r5| j t& 5 t j | }
d d d y y # 1 sw Y xY wc c}w c c}w # 1 sw Y xY w# 1 sw Y uxY w# 1 sw Y y xY w) Nr r r r6 r r r+ r1 howdy)r r r rl rE r r rS r r shmr+ rk r r3 rk r rz r{ r )rp smm1rV lolr6 lomdoppleganger_list0doppleganger_shm0 held_name
absent_shmsmm2r r absent_sls r -test_shared_memory_SharedMemoryManager_basicsz?_TestSharedMemory.test_shared_memory_SharedMemoryManager_basicsN s '';;=
z
* & 1 % &
6;ArlD""58,DD38S"3EGa!!q!)GG * 8 8c!fjjoo N /0!4 ) 6 6CFKK H $5$9$9 :B?FKK
<<7 " ""#45
H * 7 7Y G
H
%
%
9
9
; $t##G,B###-C I $ <<7 """#45
H ) 7 7Y G
H
H #- & & EG
H
H $ $
H
Hs; I-!I& I+I0:I<8JI#0I9<JJc | t j g d }| j |j j | j |j j t | | j t t | t | | j t 5 |d d d d | j t 5 d|d< d d d |j d }d|d< | j ||j d | j |j d | j t | d t j 5 t j" d | j t$ 5 |j' d d d d | j |j' d d
d d d | j |d d | j |d d | j t) | d d
|d
< | j |d
d
d|d< | j |d d | j |j d | j+ t$ d 5 d|d< d d d | j |d d d|d< | j |d d | j |d d | j+ t$ d 5 d|d< d d d | j |d d | j+ t$ d 5 d|d< d d d | j |d d t j 5 t j" d | j |j- d
d | j |j- d d | j |j- d d d d d | j/ d }t j || } | j1 |j j |j j | j ||j j | j t | t | | j |j |j d|d < | j |d d | j1 |d d |j j3 |j j t j |j j }| j |j j |j j d |d < | j |d d |j j3 |j j3 t j } | j t | d | j |j d | j |j- d d | j t$ 5 |j' d d d d |j j3 |j j y # 1 sw Y xY w# 1 sw Y xY w# 1 sw Y
xY w# 1 sw Y xY w# 1 sw Y BxY w# 1 sw Y xY w# 1 sw Y xY w# 1 sw Y xY w# |j j w xY w# 1 sw Y xY w# |j j w xY w) N)r HoWdYgX9vqr) NTrX r
r r r z8s8sdqxxxxxx?xxxxxxxx?qignore100r) r r TrX somera z8s8sdq8sxxxxxxx?qzexceeds available storagez far too manyu encodésr r u encodéess 123456789s adiostest03_duplicater M rA ip r any)r r rc r r rm r+ rn r rl
IndexError_get_packing_formatrk r r warningscatch_warnings simplefilterrE r r rT r r r" r )rp r current_formatname_duplicatesl_copy sl_tetheredempty_sls r 'test_shared_memory_ShareableList_basicsz9_TestSharedMemory.test_shared_memory_ShareableList_basicsl s
(
( >
&
bffkk3r7+
c$r(mSW-
z
* qE
z
* BqE //21 )?)?)BC
$=>
R!$
$
$
& / ! !( +"":.
RXXc]A . /
A( B&
"I >
1 A#1 A' $78
#
#J$?A #"BqE #
A'1 A
+ A)
#
#J$?A BqE
A)
#
#J$?A ! BqE !
A)
$
$
& 4 ! !( + RXXb\1 - RXXh / 3 RXXh / 3 4 ++,>? --b~F
! W[[-=-= > ^W[[-=-= > T"XtG} 5 RYY 7 GBK WR[" - 2 + KK KK $11rvv{{C koo&:&:; B B%
!..0 " S]A . X__b 1 X^^E 2A 6"":.
%t$
% LL LL !I $
/ /. # # ! ! 4 4(
KK "
%
%
LL !s .Z Z!+Z3 Z& )Z3:[ "[
[A9['<C3[4 A-\ =\"\ ZZ#&Z0 +Z33Z= [
[[$'[14 \\ \ \;c t t j dz D ] }| j | 5 t j
t d }| j
|j j t j || }t j | }| j |t j
| j |d d | j || d|d< | j |d d d |d
< | j |d
d t j
t d }| j
|j j t j || }| j t | t | |j j |j j |j j d d d y # 1 sw Y xY w) Nr r r6 r rA r changedra newvaluer i )rS r r r r r rc r r r r r rk assertIsNotr r )rp r r
serialized_sldeserialized_sl larger_slserialized_larger_sls r )test_shared_memory_ShareableList_picklingz;_TestSharedMemory.test_shared_memory_ShareableList_pickling s 622Q67 E E *
"00r;
. & R% @
"(,,}"=%%#]%@%@B !4a8 _5%." A 2"1 !3Z@ ) 7 7c
C
4 45'-||I'N$ ]!3S9M5NO
##% ##))+ /
s F7G66H c t t j dz D ] }| j | 5 t j
t d }t j || }|j j |j j | j t 5 t j | d d d d d d y # 1 sw Y xY w# 1 sw Y xY w)Nr r r6 r )
rS r r r r r r r r r rl r r )rp r r r2 s r 5test_shared_memory_ShareableList_pickling_dead_objectzG_TestSharedMemory.test_shared_memory_ShareableList_pickling_dead_object s 622Q67 0E E *
0"00r; & R% @
&&'89 0LL /0
0
0 00 0
0
0s$ A?C&1CC&C# C&&C/ c d}t j t j dd|gt j t j 5 }|j
j
j j }|j |j d}t j t j | D ] } t j |d } t" j$ dk( rSt' j( d | d
|j* j- j }| j/ d | d d d y # t $ r Y {w xY w# 1 sw Y y xY w) 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)
subprocessPopenrz r PIPEr readlinestripdecoder r r sleeping_retryr r r r rB r+ r(
unregisterr r rm )rp r r r+ err_msgr r rq s r 4test_shared_memory_cleaned_after_process_terminationzF_TestSharedMemory.test_shared_memory_cleaned_after_process_termination s:
s~~tT3 ?%/__%/__6 J9:88$$&,,.557D
KKM
FFH;G ++G,@,@'J
'44T%HC
ww'! !++avJH
hhmmo,,.
DEHJ= J J ) J Js2 B E"
E!A(E" E E" E E""E+N)ru rv rw r rM r r r r r r r r rF ry rB r+ r r
r r- r6 r8 rE rZ r r r r 4 s #M ) n`3, BB4
. 8 X__RWW')NO P. X__RWW')IJ K (H<o"b 6 0 +Jr r c b e Zd ZdZd Zd Zed Zd Z e j d d Z y)
_TestFinalizer c t j j | _ t j j y r )r _finalizer_registryr registry_backupr r s r r z_TestFinalize.setUp; s+ # 7 7 < < > &&(r c t j | j t j t j j | j y r )rm rn r r rI updaterJ r s r r z_TestFinalize.tearDown? s9
112 ''(<(<=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 |j t j d y )Nc e Zd Zy))_TestFinalize._test_finalize.<locals>.FooNr rZ r r r rO F r r )r r )r )r )d10r )rQ exitpriority)d01r )d02)d03)r i)STOPi)
r< r Finalizer rm rn _exit_functionr rB _exit) r r2 r r r close_br rQ rS rT rU s r _test_finalizez _TestFinalize._test_finalizeD sG &
E
a0
E--4996:
E
a0e
c4998!De
c4998!De
c4998!De
c4998!D
dDIIFE
dDIIIDI
r c , | j \ }}| j | j |f }d|_ |j |j t
|j d D cg c] }| }}| j |g d y c c}w )Nr TrV )r r rQ rU rT rS r ) r r r[ r r r r r rk )rp r2 r r r# rY s r
test_finalizez_TestFinalize.test_finalizel sy 99;j LL 3 3:-L H !%dii!89##99 !LM :s 1 Br 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 t j
| t j | t j y # 1 sw Y JxY w# t j
| t j | t j w xY w) Nc y r rZ rZ r r cbz,_TestFinalize.test_thread_safety.<locals>.cbz r c e Zd Z fdZy)-_TestFinalize.test_thread_safety.<locals>.Fooc l | | _ t j | t j dd y )Nr r) )rR )rl r rW r randint)rp r` s r r z6_TestFinalize.test_thread_safety.<locals>.Foo.__init__~ s%
dBV^^As5KLr N)ru rv rw r )r` s r r rc } s
Mr r Fc sCt j t j dz t j sBy y # t
$ r } | Y d } ~ d } ~ ww xY wrF )r r r r _run_finalizersrh )r r3 finishs r run_finalizersz8_TestFinalize.test_thread_safety.<locals>.run_finalizers sL
6==?T12 ((* ! C s A A AA c i } s9 t d D ch c] } c}| t j d < s8y y c c}w # t $ r }|| j Y d }~*d }~ww xY w)Nr6 r )rS r getrandbitsrh r )r: rV r r r3 rh s r make_finalizersz9_TestFinalize.test_thread_safety.<locals>.make_finalizers se A @ERy/I!/IAf((+, 0J CGGII s'
A A A A A*A%%A*gư>r r r T)r< rz getswitchintervalrm r setswitchintervalr r r r
start_threadsr r rn )
rp ri rl old_interval
old_thresholdr r r` r3 rh s
@@@@r test_thread_safetyz _TestFinalize.test_thread_safetyw s& M& M
,,. ((*
! !$ ' Q1 % ''~> ''?AG!//8
3
! !, / m , JJL
! !, / m , JJLs% A-D- D! D- !D*&D- -=E*N) ru rv rw r r r r r[ r] r r rr rZ r r rG rG 7 sM "M)>
% %N N W u%4 &4r rG c e Zd Zd Zd Zy)_TestImportStarc dd l }t j j t j
}t j j
|j | d }|j | }|D cg c]D }t j j t j j | d d F }}|D cg c] }d|z }}|j d |j d |S c c}w c c}w )Nr z*.pyr zmultiprocessing.zmultiprocessing.__init__r ) globrB r dirnamer __file__r escapesplitextsplitr rX )rp rv folderpatternfilesr modulesr s r get_module_namesz _TestImportStar.get_module_names s !9!9:'',,t{{6 2F; '"EJK277##BGGMM!$4Q$78;KK3:;a%);;12() L;s
6A C7 C<c | j }t j dk( r4|j d |j d |j d n(|j d t s|j d t
|j d |D ]n }t
| t j | }| j t |d | |j D ]# }| j t || |d| % p y ) Nr1 zmultiprocessing.popen_forkz multiprocessing.popen_forkserverz!multiprocessing.popen_spawn_posixz!multiprocessing.popen_spawn_win32z multiprocessing.sharedctypes__all__z does not have attribute ) r rz r{ r r$ r< r/ r r r7 r )rp r r+ modattrs r test_importz_TestImportStar.test_import s '') <<7 " NN7 8 NN= > NN> ? NN> ? AB = NN9 : D t ++d#C OOGC 3T :
C&7:DA
r N)ru rv rw r r rZ r r rt rt s r rt c , e Zd ZdZd Zed Zd Zy) _TestLoggingr c t j }|j t j | j |d u |j
d |j d |j t y )Nzthis will not be printedz
nor will this) r
get_loggersetLevelr
SUBWARNINGr debuginfo LOG_LEVEL)rp loggers r test_enable_loggingz _TestLogging.test_enable_logging sV ++-( d*+ /0 O$ "r c j t j }|j |j y r )r r r getEffectiveLevel)r r2 r s r _test_levelz_TestLogging._test_level s% ++- &**,-r c . d}d}t j }t j }|j }t j
d \ }}|j
| | j | j |f }|j | j ||j |j |j |j
t j |j
| | j | j |f }|j | j ||j |j |j |j
| |j
t y )Nr % Fr r )level)r r logging getLoggerr r r r r r rk r r r NOTSETr ) rp LEVEL1LEVEL2r root_logger
root_levelr r r s r
test_levelz_TestLogging.test_level s# ++- '') &&
(--U; LL 0 0yL A / ' V$ LL 0 0yL A / Z(i(r N)ru rv rw r r r r r rZ r r r r s% "M# . .)r r c ` e Zd ZdZed Z ej ee d d d Z
y)_TestPollEintrr c v t j d t j |t j
y rF )r r rB rD r8 SIGUSR1)r r s r _killerz_TestPollEintr._killer' s
3
V^^$r r requires SIGUSR1c dgfd}t j }t j t j | } | j | j
|f }|j
| j t j d }|j
|j |j | j d | j |j d t j t j | y # |j w xY w# t j t j | w xY w)NFc dd< y )NTr rZ )rQ
got_signals r recordz._TestPollEintr.test_poll_eintr.<locals>.record/ s JqMr r )r r )
rB r r8 r r r r r r r r rk r )rp r r
oldhandlerkillerr r s @r test_poll_eintrz _TestPollEintr.test_poll_eintr, s W
!iik]]6>>6:
6\\ SF\CF LLN
LL
L>
OOJqM * QZZ + MM&..* 5
MM&..* 5s& .D- 2AD 3A D- D**D- -&EN) ru rv rw r r r rF r r7 r8 r rZ r r r r # sE "M% % X35GH6 I6r r c > e Zd Z ej ed d Zy)TestInvalidHandleskipped on Windowsc t j j d } |j d |_ | j t t
ft j j d y # t t
f$ r Y Nw xY w# d |_ w xY w)NiMrA )r r*
Connectionr rE r _handlerl r s r test_invalid_handlesz&TestInvalidHandle.test_invalid_handlesG sy ))44X> IIK DL :w/)44?? E
G$
DLs# A. .B =B ?B B B N)ru rv rw rF ry WIN32r rZ r r r r E s$ X__U 01 E 2 Er r c e Zd Zd Zd Zy) OtherTestc G d dt }| j t j t j j
| d y )Nc e Zd Zd Zd Zy)FOtherTest.test_deliver_challenge_auth_failure.<locals>._FakeConnectionc y)N something bogusrZ rp rq s r r zQOtherTest.test_deliver_challenge_auth_failure.<locals>._FakeConnection.recv_bytes] s )r c y r rZ rp r s r r zQOtherTest.test_deliver_challenge_auth_failure.<locals>._FakeConnection.send_bytes_ r N)ru rv rw r r rZ r r _FakeConnectionr \ s
*
r r abc)r< rl r r
r* deliver_challengerp r s r #test_deliver_challenge_auth_failurez-OtherTest.test_deliver_challenge_auth_failure[ s= f
/==)44FF)+V 5r c G d dt }| j t j t j j
| d y )Nc e Zd Zd Zd Zd Zy)EOtherTest.test_answer_challenge_auth_failure.<locals>._FakeConnectionc d| _ y r )r r s r r zNOtherTest.test_answer_challenge_auth_failure.<locals>._FakeConnection.__init__g s
r c | xj dz
c_ | j dk( rt j j S | j dk( ryy)Nr r r r )r r r*
_CHALLENGEr s r r zPOtherTest.test_answer_challenge_auth_failure.<locals>._FakeConnection.recv_bytesi s=
a
::?*55@@@ZZ1_-r c y r rZ r s r r zPOtherTest.test_answer_challenge_auth_failure.<locals>._FakeConnection.send_bytesp r r N)ru rv rw r r r rZ r r r r f s
r r r )r< rl r r
r* answer_challenger s r "test_answer_challenge_auth_failurez,OtherTest.test_answer_challenge_auth_failuree s= f
/==)44EE)+V 5r N)ru rv rw r r rZ r r r r X s 55r r md5c " e Zd ZdZd Zd Zd Zy)ChallengeResponseTests supadupasecretkeyc V t j j | j | S r )r r* _create_responser )rp messages r create_responsez%ChallengeResponseTest.create_response| s$ )):: LL'
r c X t j j | j || S r )r r* _verify_challenger )rp r responses r verify_challengez&ChallengeResponseTest.verify_challenge s& ));; LL'8
r c . dD ] }| j d| 5 d}|rd|j d z }nd}||z }| j | }|j | s| j | | j || d d d y # 1 sw Y xY w)N)Nr r zalgo=s is-twenty-bytes-longs {%s}re r )r r r
startswithri r )rp algor r r s r test_challengeresponsez,ChallengeResponseTest.test_challengeresponse s + 5D j)
5- $t{{7'; ;F F sl //4 **62IIh'%%c84
5
5 5
5
5s A&B B N)ru rv rw r r r r rZ r r r r w s #G
5r r c . | xj dz
c_ y r )r= )nss r initializerr s GGqLGr c $ e Zd Zd Zd Zd Zd Zy)TestInitializersc t j | _ | j j | _ d| j _ y r )r Managermgrr r r= r s r r zTestInitializers.setUp s1 "**,(($$& r c l | j j | j j y r )r r r r s r r zTestInitializers.tearDown s
r c P t j j }| j t |j
d |j t | j f | j | j j d |j |j y r ) r r SyncManagerrl TypeErrorr r r rk r= r r )rp r s r test_manager_initializerz)TestInitializers.test_manager_initializer sj $ $ 0 0 2 )QWWa0 dggZ( q)
r c ( | j t t j d t j dt | j
f }|j
|j | j | j
j d y )Nr )r )
rl r r r r r r r rk r= rO s r test_pool_initializerz&TestInitializers.test_pool_initializer sa )_%9%9qI K$'' < q)r N)ru rv rw r r r r rZ r r r r s
*r r c \ | j d }y # t j $ r Y y w xY w)NF)block)r r r )r items r _this_sub_processr s-
uu5u! ==
s ++c t j } t j t | f }d|_ |j |j
y rM )r r r r r r r )r" subProcs r
_test_processr s> ! ! #E %%->eXNGGN MMO LLNr c | | z S r rZ r s r _afuncr r r c t j d } | j t g d }| j | j y )Nra r )r r r ra r r r
)r r r r r r )r r? s r pool_in_processr s5 ! ,D ./AJJLIIKr c . e Zd Zd Zed Zd Zd Zy)
_file_likec || _ d | _ y r ) _delegate_pid)rp delegates r r z_file_like.__init__ s ! r c | t j }|| j k7 r|| _ g | _ | j S r )rB r r _cacher s r cachez_file_like.cache s1 iik $)) DI DK{{r c : | j j | y r )r rX r s r r, z_file_like.write s
$ r c z | j j dj | j g | _ y )Nr )r r, r r r r s r flushz_file_like.flush s( RWWTZZ 01 r N)ru rv rw r propertyr r, r rZ r r r r s% r r c e Zd Zd Zd Zd Zy)TestStdinBadfiledescriptorc x t j t }|j |j y Nr )r r r r r )rp r s r test_queue_in_processz0TestStdinBadfiledescriptor.test_queue_in_process s$ &&m<
r c x t j t }|j |j y r )r r r r r rO s r test_pool_in_processz/TestStdinBadfiledescriptor.test_pool_in_process s$ # #? ; r c t j }t | j d t j
fd }j
y )NrS c $ j S r )r )flikes r r z:TestStdinBadfiledescriptor.test_flushing.<locals>.<lambda> s
ekkm r r )r r r r, r r r )rp sior r s @r
test_flushingz(TestStdinBadfiledescriptor.test_flushing s= kkm3
E &&.CD
r N)ru rv rw r r r rZ r r r r s
'r r c e Zd Zed Zd
dZed Zd
dZd Zd Z e
j d d Z ed Z
e
j d d
Zd Zy )TestWaitc t d D ]S }|r*t j t j dz |j |t j f U |j y )Nr6 r. )rS r r r r rB r r )r r slowrV s r _child_test_waitzTestWait._child_test_wait sQ r %A
6==?3./
FFAryy{# $ %
r c ddl m} g }g g }t d D ] }t j d \ }}t j
| j ||f }d|_ |j |j |j | j | | j |j |r2 || D ]$ } |j } |j | & |r2|j! t# fdt d D }
| j% ||
y # t $ r$ |j | |j Y w xY w)
Nr r4 ra Fr r Tc 3 H K | ] }D ] }||j f y wr )r )r rV r ry s r r z%TestWait.test_wait.<locals>.<genexpr>' s% GGA1aee*G*Gs "r6 )multiprocessing.connectionr rS r r r r r r r rX rc r r r r r r rk ) rp r r readersmessagesrV r( r r r rZ ry s @r test_waitzTestWait.test_wait s( 3q $A"''u5DAq ''t/D/DAt9UAAH
GGI
GGI NN1 LLO OOAFF # $ ']
))&&(C
OOC(
)
GeBiGG 8, NN1%GGI s D22*E E c , t j }|j | t d D ]Q }|r*t j t j
dz |j
d|z j d S |j y )Nr6 r. %s
re ) r\ r rS r r r rb r r )r r r r rV s r _child_test_wait_socketz TestWait._child_test_wait_socket* sl MMO 'r 4A
6==?3./
IIvz))'2 3 4
r c ddl m} t j t j
df }|j
}g }g }i }t d D ]h }t j | j ||f } d| _ | j |j | | j | j j t d D ]+ }|j! \ }
} |j |
g ||
< - |j# |rY || D ]K }
|
j% d } | s"|j' |
|
j# 8||
j | M |rYdj d t d D j) d
}
|j+ D ]# }| j- d j | |
% y ) Nr r4 ra r Tr r c 3 & K | ] }d |z yw)r NrZ r s r r z,TestWait.test_wait_socket.<locals>.<genexpr>S s 9!6A:9s r6 re r )r r r\ r] r r r^ rS r r r r r rX rc r r1 r r r r rH rk )rp r r r r r ry dicrV r r( r r rZ vs r test_wait_socketzTestWait.test_wait_socket4 s} 3 -"4"4a!8 9}}q $A ''t/K/K.2D\;AAH
GGI LLO OOAFF #
$ q A88:DAq NN1 CF
']
'ffRjNN1%GGIFMM#&
' 779uRy99@@I 4A SXXa[( 3 4r c & | j d y rH )r r s r test_wait_slowzTestWait.test_wait_slowW s t r c & | j d y rH )r! r s r test_wait_socket_slowz TestWait.test_wait_socket_slowZ s d#r rr c ddl m} d}t j \ }}t j
} |||g| }t j
|z
}| j
|g | j ||dz | j ||dz |j d t j
} |||gd }t j
|z
}| j
||g | j |d y )Nr r4 r r r r 皙?)
r r r r r r rk r# r< r )rp r rZ r r r r r4 s r test_wait_timeoutzTestWait.test_wait_timeout] s 3 ##%1 Aq68$ 5( b! x!|, 5(S.1 t Aq62 5( qc" s#r c N |j t j | y r )r\ r r )r rk periods r signal_and_sleepzTestWait.signal_and_sleepu s
6r c ddl m} d}d }t j d }t j \ }}t j
| j ||f }|j | j |j t | j |j d t j } |||j |g|dz } t j |z
}
| j | |j g | j! |
|dz | j# |
|dz
|j% d t j } |||j |gd } t j |z
}
| j || ||j |g | j! |
d |j% d t j } |||j |gd } t j |z
}
| j || |||j |g | j! |
d |j' |j) y )
Nr r4 r c t | d S )Nc t | S r )rU r s r r z>TestWait.test_wait_integer.<locals>.<lambda>.<locals>.<lambda> s
BqE r )rS )r )r s r r z,TestWait.test_wait_integer.<locals>.<lambda> s
F1/ : r r r r r r' )r r r rn r r r+ r r rb rI r r[ r r rk r# r< r r r ) rp r rZ sorted_rk r r r r r r4 s r test_wait_integerzTestWait.test_wait_integerz s 3: ''* ##%1 # #4+@+@*-x
:
ajj#. B /0 Aqzz1%x"}5 5( qzzl+ x!|, 5(Q,/ t Aqzz1%r* 5( w
A'?@ s# t Aqzz1%r* 5( w1::q/A'BC s#
r c 2 ddl m} t j \ }}t j
} ||gd }t j
|z
}| j
|g | j |d |j |j y )Nr r4 rA r r ) r r r r r r rk r# r )rp r r r r r s r test_neg_timeoutzTestWait.test_neg_timeout sr 3 ##%1 NN A3# NN q b! 1 r Nr )ru rv rw r r r r r! r# r% r r r( r+ r0 r2 rZ r r r r s -< !4F $ W z*$ +$. W z*) +)V r r c p e Zd Z ej ed d Z ej ed d Zy)TestInvalidFamilyr c | j t 5 t j j d d d d y # 1 sw Y y xY w)Nz\\.\testrl rE r r* r, r s r test_invalid_familyz%TestInvalidFamily.test_invalid_family s9
z
* = & & / / < = = = ?Az skipped on non-Windows platformsc | j t 5 t j j d d d d y # 1 sw Y y xY w)Nz/var/test.piper6 r s r test_invalid_family_win32z+TestInvalidFamily.test_invalid_family_win32 s>
z
* B & & / /0@ A B B Br8 N) ru rv rw rF ry r r7 r r: rZ r r r4 r4 sI X__U 01= 2= X BCB DBr r4 c 2 e Zd Zed Zed Zd Zy) TestFlagsc T |j t t j y r )r r rz flagsr r2 s r run_in_grandchildzTestFlags.run_in_grandchild s % "#r c dd l }t j | }|j d \ }}|j | j
|f }t
j t 5 |j d d d |j }|j |j |j t t j |f}t! |j# | y # 1 sw Y xY w)Nr Fr r )category)jsonr rO r r r@ r% r& DeprecationWarningr r r r r rz r> printr ) r rS rC mpr( r r grandchild_flagsr> s r run_in_childzTestFlags.run_in_child s
(
(
6wwew$1 JJc 3 31$J ?
$
$.@
A
GGI 668 syy!#34
djj s 'C66C?c dd l }dt j d}t j t
j dddd|g }|j |j d \ }}| j || y ) Nr zIfrom test._test_multiprocessing import TestFlags; TestFlags.run_in_child()r: z-Sz-Or re )
rC r rP r< check_outputrz r r rA rk )rp rC progr child_flagsrG s r
test_flagszTestFlags.test_flags sz
&&5&F&F&H%K1
N
&&
^^T4tT :<(,
4;;w3G(H% % &67r N)ru rv rw r r@ rH rN rZ r r r< r< s- $ $ ! !
8r r< c " e Zd Zed Zd Zy) TestTimeoutsc t j d |j d |j t j
j
| }|j d |j y )Nr r r )r r r r r r* r0 )r childr r2 s r
_test_timeoutzTestTimeouts._test_timeout sK
1
3
))009 #
r c t j } t j d t j d \ }}t j
j
d }t j | j ||j f }|j |j | j |j d |j |j }| j |j d |j |j t | t j | y # t j | w xY w) Nr. Tr AF_INETr( r r r )r\ getdefaulttimeoutsetdefaulttimeoutr r r* r, r rS r r r rk r r1 r& )rp old_timeoutparentrR r r r2 s r r5 zTestTimeouts.test_timeout s ..0 2 $ $S ) + 0 0 =MFE **3393EA ''t/A/A.3QYY-?AA
GGI KKM V[[]C 0 LLN88:D TYY[# . JJL
GGI O $ $[ 1F $ $[ 1s D&E E)N)ru rv rw r rS r5 rZ r r rP rP s 2r rP c e Zd Zd Zy)TestNoForkBombc t j }t j j t j j t d }|dk7 rSt j j j || \ }}}| j |d | j d| y t j j j || \ }}}| j |j d | j |d y )Nzmp_fork_bomb.pyrg r s RuntimeErrors 123)r rP rB r r rw rx r= r r assert_python_failurerk rm r r )rp rw r+ rh r rq s r test_noforkbombz TestNoForkBomb.test_noforkbomb s
-
-
/ww||BGGOOH 57HI
< <<55KKDRTULBS S# & MM/3 / <<55FFtRPLBS SZZ\6 2 S# &r N)ru rv rw r^ rZ r r r[ r[ s
'r r[ c " e Zd Zed Zd Zy)TestForkAwareThreadLockc " |dkD rRt j | j |dz
|f }|j |j t | n(|j
t t j |j y )Nr r )
r r rR r r r& r r r _afterfork_registry)r r r2 r s r rR z TestForkAwareThreadLock.child! s` q5 ''syy!T{KA
GGI JJL O IIc$223 4
r c n t j d \ }}t j }t t j
}t j | j d|f }|j |j |j }t | | j || y )NFr r )
r r r ForkAwareThreadLockr rb r rR r r r r& assertLessEqual)rp r( r r old_sizer new_sizes r r` z!TestForkAwareThreadLock.test_lock, s ##E*1 $ $ &t//0 # #4::QF C 668Q Xx0r N)ru rv rw r rR r` rZ r r r` r` s
1r r` c . e Zd Zd Zd Zed Zd Zy) TestCloseFdsc 8 t r"t j j S t j j }g }|dk r,|j | t j
| }|dk r,|D ] }t j | |S )Nrq )r r\ detachrX rB dupr )rp r to_closer? s r get_high_socket_fdz TestCloseFds.get_high_socket_fd= s ==?))+ + '')BHr'#VVBZ r'
Ir c t rCt j t j t j | j y t j | y )N)r )r r\ rU SOCK_STREAMr rB )rp r s r r zTestCloseFds.closeO s3 MM&..&*<*<R H N N P HHRLr c t j |t j t j }|j |j d y # t $ r}|j | Y d }~y d }~ww xY wr )r\ fromfdrU rp r r rh )r r2 r r r s r _test_closefdszTestCloseFds._test_closefdsU sX
b&..&2D2DEA
GGI IIdO IIaLL s 3A A; A66A;c t st j d t j \ }}| j } t j | j ||f }|j |j |j }t | | j | |j |j t j dk( r| j |d y d}| j |t | j! |j" t" j$ k( xs |j& |k( | y # | j | |j |j w xY w)Nzrequires fd picklingr rg i6' )r$ rF rG r r rn r rs r r r r& rP ro r r r r r winerror)rp r r r r r WSAENOTSOCKs r test_closefdzTestCloseFds.test_closefd_ s ##$:; ;(--/
$
$
&
''t/B/B.4b\;A
GGI LLN
A O JJrN LLN LLN + + - 7 MM!T " K ! !!W - OOAGGu{{ 2 6 JJ+ 5q
:
JJrN LLN LLNs
A E 3FN)ru rv rw rn r r rs rw rZ r r ri ri ; s% $ :r ri c e Zd Z eej
ej Zed Z e
j e e
d d d Zed Z e
j e e
d d d Zy)TestIgnoreEINTRc d }t j t j | |j d |j }|j | |j d| j
z y )Nc y r rZ r frames r r5 z-TestIgnoreEINTR._test_ignore.<locals>.handler ra r ready x)r8 r r r r
CONN_MAX_SIZE)r r2 r5 r? s r _test_ignorez TestIgnoreEINTR._test_ignore sR
fnng. ' IIK ! s 0 001r r r c t j \ }} t j | j |f }d|_ |j |j
| j |j d t j d t j |j t j t j d |j! d | j |j d t j d t j |j t j | j |j# d| j$ z t j d |j' |j
y # |j
w xY w)Nr Tr~ r. i r )r r r r r r r rk r r r rB rD r r8 r r r r r r s r test_ignorezTestIgnoreEINTR.test_ignore s *//1j ''t/@/@.8]<AAH
GGI TYY[' 2 JJsO GGAEE6>> * JJsO IIdO TYY[$ / JJsO GGAEE6>> * T__ .t7I7I0I J JJsO
FFH JJLDJJLs FF1 1Gc 0 d }t j t j | t j j 5 }|j |j |j }|j d d d d y # 1 sw Y y xY w)Nc y r rZ r| s r r5 z6TestIgnoreEINTR._test_ignore_listener.<locals>.handler ra r welcome)r8 r r r* r, r r r1 )r r2 r5 r r s r _test_ignore_listenerz%TestIgnoreEINTR._test_ignore_listener si
fnng.
'
'
0
0
2 a IIaii
A
FF9 s =B Bc ~ t j \ }} t j | j |f }d|_ |j |j
|j }t j d t j |j t j t j d t j j! | }| j# |j d |j% |j
y # |j
w xY w)Nr Tr. r )r r r r r r r r r r rB rD r r8 r r* r0 rk r )rp r2 r r r r3 s r test_ignore_listenerz$TestIgnoreEINTR.test_ignore_listener s *//1j ''t/I/I.8]<AAH
GGI iikG JJsO GGAEE6>> * JJsO$//66w?F V[[]I 6
FFH JJLDJJLs D D* *D<N)ru rv rw maxr
PIPE_MAX_SIZE
SOCK_MAX_SIZEr r r rF r r7 r8 r r r rZ r r ry ry } s --w/D/DEM2 2 X35GH I, X35GH Ir ry c e Zd Zed Zd Zd Zd Zd Zd Z d Z
e j e
j dk( d ed
d Zed Zed
Zd Zy)TestStartMethodc J |j t j y r )r r rP r? s r _check_contextz TestStartMethod._check_context s /2245r c J |j d \ }}|j | j |f }|j |j |j }|j |j
| j ||j y )NFr r ) r r r r r r r rk rP )rp rs r( r r child_methods r
check_contextz TestStartMethod.check_context sx xxux%1 KKt 2 2!K > vvx s';';'=>r c dD ] } t j | }| j |j | | j |j | | j
t |j d | j
t |j d | j | y # t $ r Y w xY w)Nrg rN r rN ) r rO rE rk rP ro rl rj r )rp methodrs s r r) z TestStartMethod.test_context s 5 $F
%11&9
S 1 1 3V < MM#//+S 1 j#*>*> H j#*>*> E s # $
s B22 B>=B>c t j d }| j t d 5 |j g d d d d y # t $ r t j d w xY w# 1 sw Y y xY w)Nr z forkserver should be availablez&module_names must be a list of stringsr )r rO rE rF rG rT r set_forkserver_preload)rp rs s r test_context_check_module_typesz/TestStartMethod.test_context_check_module_types sx F!--l;C
#
#I/W
X 2 & &y 1 2 2 F##$DE E F 2 2s A
A,
A),A5c < t j t d}t j } dD ] } t j |d | j
t j | t j }| j
|j | | j t | j j j | | j |j j j j | | j t |dz
} t j |d | j |d y # t
$ r Y Kw xY w# t j |d w xY w)Nr r Tre r )r r PRELOADrP rj rE rk rO r r ru lowerr r r r3 )rp r
old_methodr rs s r test_set_getz TestStartMethod.test_set_get sG ..w7$557
E9
#44V4H !A!A!CVL%113 !5!5!7@S 2 2 8 8 : E Ef MNKK((..0;;FCE""?3
, ,Zt D q) "
, ,Zt Ds/ F E2C8F 2 E?;F >E??F Fc t j }t j dk( r| j |dg y | j |ddgk( xs |ddgk( xs |g dk( xs |g dk( y )Nr1 rN rg r )rN rg r )r get_all_start_methodsrz r{ rk r )rp methodss r test_get_allz TestStartMethod.test_get_all sz !779 <<7 " Wwi 0 OOG'8 8 G #'8 8 G #'F F G $'F F
Hr c t j dk7 r| j d t j j t j j
t d }t j j j | \ }}}|j }|j }|j dk7 s|dk7 r(t | t | | j d y y )Nr z*test only relevant for 'forkserver' methodz
mp_preload.pyokr z(failed spawning forkserver or grandchild)r rP r rB r r rw rx r= r r r rA r rE ri )rp r+ rh r rq s r test_preload_resourcesz&TestStartMethod.test_preload_resources s + + - = MMF Gww||BGGOOH 5G||11BB4H Cjjljjl ::<4 3"9 #J #J II@ A $-r r1 z*Only Spawn on windows so no risk of mixingavoids redundant testing.c N dD ] }t j d j }t j | }|j t |f }d}| j t | 5 |j d d d dD ] }t j D ]r }t j | j }t j | }|j t |f }|j |j t y # 1 sw Y !xY w)N)rN r rg r zA SemLock created in a fork)
r rO r r r# rT r4 r r r )rp process_methodr" process_ctxr rD queue_methods r test_mixed_startmethodz&TestStartMethod.test_mixed_startmethod s
6 N#//7==?E)55nEK##;eX#FA3G'' g>
4 L"1"G"G"I
'33LAGGI - 9 9. I ''{%'J
s .DD$ c & |j d y r r )r r" s r _put_one_in_queuez!TestStartMethod._put_one_in_queue% s
! r c |j d t j | j |f }|j |j y rR )r r r r r r )r r" r% s r _put_two_and_nest_oncez&TestStartMethod._put_two_and_nest_once) s9
! !))1F1FeXV
r c \ t j }t j | j |f }|j |j g }|j
s0|j |j |j
s0| j |ddg y )Nr r r )
r r r r r r r rX r rk )rp r" r% r s r test_nested_startmethodz'TestStartMethod.test_nested_startmethod0 s %%'!))1L1LTYS[\
++- NN599; ' ++-
1a&)r N)ru rv rw r r r r) r r r r rF ry rz r{ r[ r r r r rZ r r r r s 6 6?
$2*,H
B X__S\\W,AC !<= >C&
*r r r c F e Zd Zd Zd Zd Zd Zd Zed Z d Z
d Z y )
TestResourceTrackerc d}t j D ] }| j | 5 |dk( r
d d d &t j \ }}t j t j dd|j || g|gt
j }t j | t |dd
5 }|j j j d }|j j j d }d d d t! | |j# |j% d | d
} t' j( t& j* | D ] }
t! | |j6 j9 j d } |j6 j dj | }
| j; | |
| j; | d|z d d d y # 1 sw Y xY w# t, $ rE} | j/ | j0 t0 j2 t0 j4 f Y d } ~ d } ~ ww xY w# 1 sw Y cxY w)Na if 1:
import time, os
import multiprocessing as mp
from multiprocessing import resource_tracker
from multiprocessing.shared_memory import SharedMemory
mp.set_start_method("spawn")
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, noopr: r )r r, )pass_fdsr r T)r re 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 rB piper< r= rz r r r> r r r? r rA r- r r r rB r r rm r ENOENTEINVALr r r )rp r r, r( r r r name1name2rD r r rq rZ s r test_resource_trackerz)TestResourceTracker.test_resource_trackerD s( : &44 $ PE E * #
PF? #
P #
P wwy1 $$cnn%)4au1M&O/0c,6OO= !T40 BA JJL / / 1 8 8 AE JJL / / 1 8 8 AEB !.
w '1 2 //0E0E29; A (6 hhmmo,,W5 &&,f !'# h/ &F&NOG#
P #
P$ PB B #
agg ell/KL /#
P #
PsV I,BI,=AHA!I,: HA=I,H I, I) $:I$ I,$I) )I,,I6 c p ddl m} |j }|Jt j |t
j t j |t
j t j 5 t j d |j d d d |j }t j || t j d t j d }t j d 5 }t j d |j# }|j% |j' t) j* | }~t- j. | j1 | |rp| j3 t5 | d
|d } | j7 t9 | j: t< | j7 d t? | j@ v n| j3 t5 | d d d d y # 1 sw Y xY w# 1 sw Y y xY w) Nr _resource_tracker)r r r' rN T)r alwaysr z resource_tracker: process died)! multiprocessing.resource_trackerr r rB rD r8 rE r wait_processr% r& r' r r r r rO rn r[ r\ rk rl rm rn r rk r r
issubclassrB UserWarningrn r )
rp r
should_dier r rs all_warnrk rp the_warns
r check_resource_tracker_deathz0TestResourceTracker.check_resource_tracker_death s G $$ ? GGC ( ?
$
$
& / ! !( + , , . / $$
V
3 ))'2
$
$D
1 3X ! !( +--/C KKM KKMS!B JJL bd # X 2#A;
8+<+<k JK @#&x'7'7#8!9 : X 2% 3 3 / / 3 3s 3&H DH, H),H5c D | j t j d y rD )r r8 r r s r test_resource_tracker_sigintz0TestResourceTracker.test_resource_tracker_sigint s ))&--?r c D | j t j d y rD )r r8 r@ r s r test_resource_tracker_sigtermz1TestResourceTracker.test_resource_tracker_sigterm s ))&..%@r c D | j t j d y rH )r r8 rE r s r test_resource_tracker_sigkillz1TestResourceTracker.test_resource_tracker_sigkill s ))&..$?r c ddl m} |j |j d |fv }||j z }| j | y )Nr r )r r r r _check_aliver )r2 r r reuseds r _is_resource_tracker_reusedz/TestResourceTracker._is_resource_tracker_reused sG F((* #''D#;6#0022 &r c ddl m} |j |j }t j
d \ }}t j | j ||f }|j |j }|j |j |j | j | y )Nr r Fr r )
r r r r r r r r r r r r r )rp r r r( r r is_resource_tracker_reuseds r test_resource_tracker_reusedz0TestResourceTracker.test_resource_tracker_reused s F((* $$ ##511 # #4+K+K*+S
3 %&VVX"
23r c d}ddt | z
z }| j t 5 t j || d d d y # 1 sw Y y xY w)Nr r r )r rl rE r( register)rp r, too_long_name_resources r test_too_long_name_resourcez/TestResourceTracker.test_too_long_name_resource sU !$c%j(8!9
z
* E % %&<e D E E Es A AN) ru rv rw r r r r r rM r r r rZ r r r r @ sA EPN#3J@A@ 4$Er r c ` e Zd Zed Zd Zd Zej j d Z
y)TestSimpleQueuec |j |j |j |j |j |j y # |j w xY wr )r r r rd r s r _test_emptyzTestSimpleQueue._test_empty sQ & IIekkm $ IIekkm $ # # % # # %s >A! !A3c t j }t j }t j }t j | j |||f }d|_ |j
| j |j |j |j | j |j | j |j d | j |j d | j |j |j y )Nr TF)r SimpleQueuer r r r r r r rd r r rk r r )rp r" r r r s r
test_emptyzTestSimpleQueue.test_empty s ++-)//1 - 3 3 5 &&## *=>
& " ' d+ e,
& r c l t j }|j |j y r )r r r rp r" s r rq zTestSimpleQueue.test_close s" ++-
r c t j }|j | j |j j
| j |j j
y r )r r r r _readerr# _writerr s r test_closedzTestSimpleQueue.test_closed sE ++-
,,-
,,-r N) ru rv rw r r r rq r= r cpython_onlyr rZ r r r r s< & &0
\\ . .r r c e Zd Zd Zy)TestPoolNotLeakOnFailurec dg G fdd }| j t d 5 t j j dt
j j | }|j |j d d d | j t d D y # 1 sw Y +xY w) Nr c 4 e Zd Z fdZfdZd Zd Zd Zy)RTestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.FailingForkProcessc R d| _ d | _ d | _ j | y )Nz Fake Process)r+ r r rX )rp rR forked_processess r r z[TestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.FailingForkProcess.__init__ s& * $
!
''-r c > dk r t d dz d| _ y )Nr Manually induced OSErrorr r )r r )rp will_fail_ins r r zXTestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.FailingForkProcess.start# s( 1$!"<== ! &
r c d| _ y )Nstoppingr r s r r z\TestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.FailingForkProcess.terminate* s '
r c 2 | j dk( rd| _ y y )Nr stoppedr r s r r zWTestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.FailingForkProcess.join- s ::+!*DJ ,r c B | j dk( xs | j dk( S )Nr r r r s r r z[TestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.FailingForkProcess.is_alive1 s zzY.J$**
2JJr N)ru rv rw r r r r r )r r s r FailingForkProcessr s
.
'
(
+
Kr r r r )r )contextc 3 < K | ] }|j y wr rs )r r% s r r zITestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.<genexpr>: s Cw "Crt ) rT r r r r rF r MagicMockr r r r" )rp r r r r s @@r test_release_unused_processesz6TestPoolNotLeakOnFailure.test_release_unused_processes s K K0
#
#G-G
H $$))!X]]5L5L* 6M 6,) -A
GGI
FFH
C2BC C E s A B44B=N)ru rv rw r rZ r r r r s $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*y#)'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 p | j | _ | j j d | _ y r )
manager_classr r r r s r r zTestSyncManagerTypes.setUpV s) ))+ r c | j N| j j r4| j j | j j | j j d | _ d | _ y r )r r r r r r r s r r z TestSyncManagerTypes.tearDown[ sW 99 TYY%7%7%9 II ! IINN r c , t j y r )r
reap_childrenr+ s r r z TestSyncManagerTypes.setUpClassc s r c t | j t }t j }t j |d D ]$ }t t j dk s$ y t j |z
}dt
_
t j dt j d|dd y ) NFerrorr T"multiprocessing.Manager still has active children after .1f seconds) r& r WAIT_ACTIVE_CHILDREN_TIMEOUTr r r rB r r r environment_altered
print_warning)rp r6
start_timer r s r wait_proc_exitz#TestSyncManagerTypes.wait_proc_exiti s TYY .^^%
''u= MA?2245: M !J.B*.G ' ! !$F%4%D%D%F$G H;;=c((#L
Mr c t j ||f | _ d| j _ | j j | j | j
| j j d y )Nr Tr )r r r r r r rk r )rp workerr# s r
run_workerz TestSyncManagerTypes.run_worker{ sX #++6H ++Q/r c f |j |j |j d y Nru )r r r r# s r r z TestSyncManagerTypes._test_event s!
r c | j j }|j | j | j | |j d y r )r r rd r r r rp rB s r r z TestSyncManagerTypes.test_event s< LL ((!, u
r c $ |j y r r[ r s r
_test_lockz TestSyncManagerTypes._test_lock
r c t | j | }| j | j | |j | j t |j y r )r r r r r\ rl r4 rp lnamerB s r r` z TestSyncManagerTypes.test_lock sF (GDLL% ( * + , 2r c D |j |j y r r[ r\ r s r _test_rlockz TestSyncManagerTypes._test_rlock
r c r t | j | }| j | j | y r )r r r r r s r rc z TestSyncManagerTypes.test_rlock s+ (GDLL% ( * ((!,r c $ |j y r r r s r rl z$TestSyncManagerTypes._test_semaphore r r c t | j | }| j | j | |j y r )r r r rl r\ )rp snamerB s r ro z#TestSyncManagerTypes.test_semaphore s4 (GDLL% ( * ,,a0 r c ( | j d y )Nrr )r% )ro r s r rs z+TestSyncManagerTypes.test_bounded_semaphore s "45r c D |j |j y r r r s r _test_conditionz$TestSyncManagerTypes._test_condition r! r c p | j j }| j | j | y r )r r r r( r s r test_conditionz#TestSyncManagerTypes.test_condition s( LL " " $ ,,a0r c $ |j y r )r r s r
_test_barrierz"TestSyncManagerTypes._test_barrier s
r c r | j j d }| j | j | y r )r r r r, r s r r z!TestSyncManagerTypes.test_barrier s* LL # **A.r c 4 |5 d d d y # 1 sw Y y xY wr rZ r s r
_test_poolz TestSyncManagerTypes._test_pool s s c t | j j d }| j | j | y )Nra r )r r r r/ r s r test_poolz TestSyncManagerTypes.test_pool s+ LL * +r c y r rZ r s r _test_queuez TestSyncManagerTypes._test_queue rY r c t | j | d }|j d |j d | j | j | y )Nr r r )r r r r r3 )rp qnamerB s r
test_queuez TestSyncManagerTypes.test_queue sC (GDLL% ( + a a ((!,r c & | j d y )Nr& )r6 r s r test_joinable_queuez(TestSyncManagerTypes.test_joinable_queue s (r c t j }|j |d d |j |j d d |j |j d d |j |j
|D ] } |j t | d |j |j d d y )Nr r r ) rF TestCaserk r r r reverser r )r r# caser? s r
_test_listz TestSyncManagerTypes._test_list s " Q# 1 q) 1 q)
A S1% Q'r c | j j }|j d | j | j | | j | | j
t | d y )Nr r )r r rX r r= rh rk r r s r r z TestSyncManagerTypes.test_list sS LL + Q Q#r c N t j }|j t | d |j |d d |j |j d d |j t
|j dg |j t
|j dg |j t
|j dg |j |j ddi |j |j d y )Nr rS r )rS r )rF r: rk r r assertListEqualr r r rH assertDictEqualr assertTupleEqualpopitemr r# r< s r
_test_dictz TestSyncManagerTypes._test_dict s " S1% UQ' + T#))+ . = T#((* -w7 T#**, /!5 SXXZ%4 ckkmZ8r c | j j }d|d< | j | j | | j | | j t
| d y )Nr rS r )r r r rE rh rk r r s r r z TestSyncManagerTypes.test_dict sQ LL % + Q Q#r c t j }|j |j d |j |j d |j d y )Nr r )rF r: rk r r rd rD s r _test_valuez TestSyncManagerTypes._test_value sE " A& A&
r c | j j dd }| j | j | | j |j
d | j |j
d y )NrV r r )r r r rH rk r r r s r rO z TestSyncManagerTypes.test_value sV LL sA & ((!, !$ !$r c t j }|j |d d |j |d d |j t | d |j t | ddg y )Nr r r )rF r: rk r r@ r rD s r _test_arrayz TestSyncManagerTypes._test_array sd " Q# Q# S1% T#YA/r c x | j j dddg }| j | j | y )NrV r r )r rl r rK r s r ro z TestSyncManagerTypes.test_array s0 LL sQF + ((!,r c t j }|j |j d |j |j d y r )rF r: rk r? r@ rD s r _test_namespacez$TestSyncManagerTypes._test_namespace s8 " " "r c | j j }d|_ d|_ | j | j
| y r )r r r? r@ r rN r s r r z#TestSyncManagerTypes.test_namespace& s6 LL " " $ ,,a0r Nre )rn )r )+ru rv rw rx r r r r r r r r r r r r r r r` r rc rl ro rs r( r* r, r r/ r1 r3 r6 r8 r= r rE r rH rO rK ro rN r rZ r r r r = s * $,,88M
MM$0 3 -
6 1 /
, )
(
($ 9 9$ % 0 0- # #
1r r c ( e Zd Z ed d Zy)TestNamedResourcezspawn specific test.c h t j }| j t j | t |dd 5 }|j t
j d d d d t j | \ }}}| j ||j d y # 1 sw Y ExY w)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 rc r r r, textwrapdedentr r r rA )rp r r rh r rq s r test_global_named_resource_spawnz2TestNamedResource.test_global_named_resource_spawn. s !! ((&1
&#
0
A
GGHOO %
%55f= C
#**W"56
s %B((B1N)ru rv rw r[ rV rZ r r rQ rQ - s !787 97r rQ c . e Zd Zd Z ed d Zy) MiscTestCasec ^ t j | t t j ddg y )NSUBDEBUGr )extra not_exported)r check__all__r r r s r test__all__zMiscTestCase.test__all__H s% T?/:Q:Q+5|*D Fr r c t j dd \ }}}| j |d | j ||j d y )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 rS )r r rk r rA )rp rh r rq s r ,test_spawn_sys_executable_none_allows_importz9MiscTestCase.test_spawn_sys_executable_none_allows_importM sQ %55
F
C
Q #**W"56r N)ru rv rw r^ r[ r` rZ r r rX rX G s" F
!!<=7 >7r rX c , e Zd Zed Zed Zy) BaseMixinc t j j j t j j f| _ y r )r r% _danglingr r danglingr+ s r r zBaseMixin.setUpClasse s5 '//99>>@!++0024 r c t j 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 }y )Nr TDangling processes: r Dangling threads: ) r= r rN rd r r% rd re r r r )r r r s r r zBaseMixin.tearDownClassj s
!//99:S a =QQ /3DLL , ! !$8 "D E i))*S a -AA /3DLL , ! !$6wi"@ Ar N)ru rv rw r r r rZ r r rb rb d s( 4 4 r rb 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 eej0 Z eej2 Z eej4 Zy)r r N)ru rv rw r r r r* rM r r r r r r r r& rZ rb rn rr r r r r rl rL rk rZ r r r r } sN D %%G ++J"?#B#BCO!/"@"@AN"?#B#BCO!/"@"@AN ,, -D ,, -D .. /E !>!>?M ,, -D .. /E _ 6 67I#O$D$DE _ 6 67I .. /E?223G .. /E .. /EO 4 45HO 4 45Hr 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 rQ r s r r zManagerMixin.Pool s s{{ ...r c T t | t j | _ y r )r r r r r r s r r zManagerMixin.setUpClass s
%--/ r c t }t j }t j |d D ]$ }t t
j dk s$ nR t j |z
}dt _ t j dt
j d|dd t j | j j d k7 rWdt j _ t j d
t j | j j | j j! | j j# d | _ t$ | M y ) NFr r Tr r r r r z5Shared objects which still exist at manager shutdown:)r
r r r rB r r r r r rm rn r _number_of_objectsr= _debug_infor r r r )r r6 r
r r r s r r zManagerMixin.tearDownClass s,
/^^%
''u= MA?2245: M !J.B*.G ' ! !$F%4%D%D%F$G H;;=c((#L
M
;; ) ) +q 0 04DLL , ! ! #9
: ! !#++"9"9"; <
r ) ru rv rw r r r r operator
attrgetterr r& rZ rb rn rr r r r r rl r r r r r r r rP rQ s @r rk rk s D %%G (X(( 9 :E 0X 0 01H IJM 'H''7 8D (X(( 9 :E,,,-@ABI 3 3 34N OP,,,-@ABI (X(( 9 :E*x**+<=>G (X(( 9 :E (X(( 9 :E 'H''7 8D 'H''7 8D,,,-@ABI/ / 0 0 r rk 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. Zy) ThreadsMixinr N)ru rv rw r r dummyr r* rM r r r r r r& rZ rb rn rr r r r r rl rZ r r rt rt st D ##++G &&11J"?#8#8#H#HIO"?#8#8#H#HIO --22 3D --22 3D ..44 5E !6!6!D!DEM --22 3D ..44 5E _ 2 2 < <=I#O$9$9$J$JK _ 2 2 < <=I ..44 5E?00889G ..44 5E ..44 5Er rt c | d }t }h d}|j D ] \ }}t |t st |t
r|t
u r1|j D ] } |r| |k7 r |rd| j z |dd z }
|| j dz } G d d|| t j } | dk( r t j d | } |
x| _ | _
|| _ | | |
< t |t j s|r G d
d|t } |x| _ | _
|| _ | | |< d d gd gfd }
fd }|
| d
< || d< y )Nru > r r r Withr Mixinc e Zd Zy*install_tests_in_module_dict.<locals>.TempNr rZ r r Tempr{ s r r| r r c e Zd Zyrz r rZ r r r| z*install_tests_in_module_dict.<locals>.Temp s r c t j t t j j t j j
j
d< t j
j
d< t j d d< t j d t j j d r t j } t% t' j( t j* j- t. y # t $ r t j dz w xY w# t" $ r t j d w xY w) Nr r Trc re z start method not supportedlinuxz1OSError raises on RLock creation, see issue 3111!)r r r r% _cleanuprd r r rP rj rE rF rG rz r{ r rb r rJ r get_temp_dirr r r )r_ re old_start_methodrS s r setUpModulez1install_tests_in_module_dict.<locals>.setUpModule s2 ..w7 ((*%--77<<> ))..0 - > >$ O C , ,\ F
<< " "7 +
;&,,. ! ""$--i8 C##L$A%B C
C C
; '' ): ; ;
;s D0 E 0"E E4c d d} t j 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 j y ) NFr Tre rg r rh r )r= r rN r rj rd r% rd r r r r r r _cleanup_tests)
need_sleepr r re r s r tearDownModulez4install_tests_in_module_dict.<locals>.tearDownModule( s
!(()9!)<DI//99:S!=MM J/3DLL , ! !$8 "D E i))*S!-== J/3DLL , ! !$6wi"@ A JJsO ++-r r r )globalsr r r r r r
capitalizerF r: r requires_hashdigestru rw rv r< ) remote_globsrS only_type
exclude_typesrv local_globs ALL_TYPESr+ basetype_newnamerx r| r r re r s ` @@r install_tests_in_module_dictr s j)J)K3I!'') &
d$% dL )|# ++
- )!3 5#3#3#55QR@#E$4$4$6$@A4(9(9 I%G>==hGMD4;;
1",(, W%
- h / /
0
tV
04 4DMD - (DO!%L ; &> d|H v9,.: #.L %3L!"r SemLockzSemLock not availabler z
Linux onlyc e Zd Zd Zy) SemLockTestsc G d dt j }dt j } |ddd|d }t j | y )Nc e Zd Zy)3SemLockTests.test_semlock_subclass.<locals>.SemLockNr rZ r r r r N rP r r ztest_semlock_subclass-r r r6 F)r r rB r
sem_unlink)rp r r+ r s r test_semlock_subclassz"SemLockTests.test_semlock_subclassM sG &.. ' }5 Aq"dE *##D)r N)ru rv rw r rZ r r r r I s *r r r rD )rF
unittest.mockr" r rT r r r rz rB rm r rW r8 rm r\ r r r< r rq r r rk r% test.supportr= test.support.script_helperr r r r r r r r
import_moduler *skip_if_broken_multiprocessing_synchronizer r r multiprocessing.dummymultiprocessing.heapmultiprocessing.managersrg multiprocessing.queuesr r
r r HAVE_SEND_HANDLEr$ ImportError multiprocessing.sharedctypesr r r r HAS_SHMEMr check_sanitizerrG r r# r& r+ r( r- r r rN r r r r r r r
r
HAVE_GETVALUEr{ r r7 rC r r ctypesr; r< r= r> r< rJ r[ r: r] r} r r r r r r r r r r rW rh rv r r r r r r r9 re r| r r r r r rE r r r rU rZ r\ rm r r r r r r r r r r r r r r r r r r r r r& r7 rB r rX ru r r r rG rt r r r r r r r r r r r r r r r4 r< rP r[ r` ri ry r ry r r r r rQ rX rb r rk rt r r7 r rZ r r <module>r s
! ' & " & & ) ( /=../AB 2 2 2 4 ! @ ) ..M 8-I
74( (
F
GG * 77g05
OO
#2 Hh#0 Hh (( " , 6? ?
#
BJJ} %E
=
> )== K 2LX . . L@ 0F 0" 6 6
* K 8< K 8d /)) ,Q7l Q7n $@ @J
03@\ 3@le\ eP 5W 5W@& &.
6F 6r x1< x1|C3 C3LM3 M3fY/l Y/~$
$F $ %: $f! f!P &L &PB l B P I HV ,I ,
56 * 56; ? 53- @4>\ 4>v
/; / kI 6KK K
{ #
. .b $ ##H-22, 22 .22p 9G/l G/R 8L 8D., .`L Ld ]$JK# ##H-@| @ . L@Lb bP
9
5) 5)p Y HI# ##H-{J {J . J{JBuL ux%h'' %V+)< +)J 6\ 6DE)) E& $ ##H-5!! 5 .5< $ ##E*# ##H-5H - - 5 . +5N $ ##H-*x(( * .*<
*'!2!2 '*mx mf
B))
B 8!! 8H 28$$ 2D 'X&& '"1h / / 1><:8$$ <:DAh'' AF}*h'' }*@ (=?\E(++ \E?\E~0.h'' 0.f&Ex 0 0 &ER $ ##H-l18,, l1 .l1^7)) 7478$$ 7: 26Y 629 9 9 x69 62 @E\4~ W -y99;RS (,7*8$$ * 8 T*_@ M I
FF E )I$((E(Hz)sf '_ :
_" _0 _> #` : ` _ _ "_-,_-0_;:_;>` ` `
`'&`'