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\ ry t j
d| z # t t f$ r Y y w xY w)Nr9 SC_SEM_NSEMS_MAXzHThe OS doesn't support enough semaphores to run the test (required: %d).)ossysconfAttributeError
ValueErrorunittestSkipTest) nsems_minnsemss r check_enough_semaphoresrJ sm KI
-.
{ey(
>@I J K K
J ' s = AAc fd}|S )Nc 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 Z e Zd Z ej ej dk( d d Zy)TestInternalDecoratorsr1 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__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 ry
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
hasattrsignalSIGALRMr0 r )rp methr r4 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 r7 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 r7 SIGKILLr@ 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 rS 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 rS r r
rM 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 rH r r7 setr )rp r^ r ra 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 ry 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 rh 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 rR r r. r r& rk r r+ r r
r rB r+ r7 r? ry rz rW rD rm )rp smNrU 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 rj rk r r r r rl rm rn rk r r# )rp r ro 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 rR r r r r rk r rc r r# ) rp rv rw r r rU rx 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
rc 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 setattrry rc )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 getattrry 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 ry 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 rC r r
r r r rk r rm )
rp signumrv 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 r7 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 r7 rD 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; rA rE rJ rO rS rZ r_ rd rh rp rz 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 TESTFNrb 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_EXCLry 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 ry r rf )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 rb r r r r r r& rk r r r rstriprn rB r ry rf ) rp r rT r r contentcasesrQ rY 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 )r6 r qsize)r s r queue_emptyr s( q'wwywwyA~ r c ` t | d r| j S | j |k( S )Nfull)r6 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 rR r rc )r r" child_can_startparent_can_continuerU 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
rM r| rl pyqueueFullr r TIMEOUT1TIMEOUT2TIMEOUT3rc 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 rc 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 rc r r r
rM 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 )Nr5 r )rR r )r r" rU 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 )Nr5 r Tr F)r rR r r r
rM r r r r rk r rl r r r r# )rp r" rU 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
rM 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 Tr5 )
JoinableQueuerR r r# r r r r r# )rp r" rU 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 NotSerializabler7 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 Z d Zd Zy)K_TestQueue.test_queue_feeder_on_queue_feeder_error.<locals>.NotSerializablec 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)rD rD r s r r zV_TestQueue.test_queue_feeder_on_queue_feeder_error.<locals>.NotSerializable.__reduce__ s )-&$$r N)ru rv rw r r rZ r r r: rA s ,
>
%r r: c $ e Zd Z e fd Zy)E_TestQueue.test_queue_feeder_on_queue_feeder_error.<locals>.SafeQueuec P t | t rt | rd|_ y y y rG )r rD rE )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 staticmethodrK )r: s r SafeQueuerI s C
@
@r rM )rs Tr )r r r r; r r r r< r r= get_contextr r r r rD rE )rp rM 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' r0 r4 r> rP rT 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 rG )RLockrk rZ r[ rl r r3 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 rY r s r test_lock_contextz_TestLock.test_lock_contextO s#
YY[ s %N)ru rv rw r_ rb re rZ r r rV rV < s MHr rV 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 rZ 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 ) Semaphorerk rk r[ r r ri s r test_semaphorez _TestSemaphore.test_semaphorec sn nnQ S! - ''9c: - ''9c:r c H | j d }| j | y Nr )BoundedSemaphorerk ri 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 rm r| rZ rk r r r
r r )rp rj rZ s r r4 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 rk rn rr r4 rZ r r rg rg T s ;;"@r rg 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 )rZ 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 wNr5 )rR r r r
rM r )rp r~ r rU 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 rw 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 ) Conditionrm r r r r rb r r r rZ r r
rM r r notifyr[ r )rp rw rx ry 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 ry s r <lambda>z0_TestCondition.test_notify_all.<locals>.<lambda> Yu-= r )r rm rR r r r
r r rb r r r rZ r r r r r
rM
notify_allr[ r| rp rw rx rU r r ry 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 rm rR r r r r rb r r r rZ r r
rM 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 rC ) r r| r rZ r
r[ rk r r )rp rw r r s r r4 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_forry rf )r rw r rX 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)
NrU rA r Tc " j dk( S Nr r r s r r z-_TestCondition.test_waitfor.<locals>.<lambda>d r r r ra rs r )r r r r r r r r rk r rR r r
r r& r )rp rw r rX rU 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 rw r successrj rY dtrX 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)
NrU r Fr Tr r rs r )r r rm r r r r r rZ r r rR r r
r r r& )rp rw r r rj r rU 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 rC r7 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 ProcessesMixinry rz 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 r4 r rF r HAS_SHAREDCTYPESr r r r r rZ r r ru ru s 5 +Z<#|0#d= X)+?@( A(. % % X)+?@' A'. ( (r ru c * e Zd Zed Zd ZddZy)
_TestEventc V t j t |j y r )r r
r rc 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
rc 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 assertRegexreprrc 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 )NrU r )r heap
BufferWrapperstructcalcsizerY __setstate__
_lengthbuf)rp wrapperr^ s r r z_DummyList.__init__ sO !&&44V__S5IJ ##% 7D/* r c ~ |\ | _ | _ | j j j d | _ y )NrU )_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 rW 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 rW r rZ r r r r s F+$&r r c . t j d y )Nrs r) rZ r r _waitr s JJtr c 4 e Zd Z ddZd Zd Zd Zd Zd Zy) Bunchc || _ || _ || _ |j | _ |j | _ |j
| _ |s| j j g }t | D ]F }|j | j }d|_ |j |j | H d } t j | | | | _ y )Nr Tc 2 | D ] }|j y r )r )r r s r finalizez Bunch.__init__.<locals>.finalize( s
r )r rQ r DummyListstartedfinishedr _can_exitrc rR r taskr r rW rj r
_finalizer)
rp namespacer rQ r wait_before_exitr rU 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 rW 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 rc 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 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 rG )r" rW r s r r zAppendTrue.__call__J s r Nr rZ r r r r G s r r c e Zd Z dZdZd Zd Zd Zd Ze d Z
d dZ d Z e d
Z
d Ze d Zd
Ze d Zd Ze d Zd Ze d Zd Ze d Zd Ze d Zd Zd Ze d Z d Z y) _TestBarrierr g >@c \ | j | j | j | _ y )Nr )Barrierrw 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 rw 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 )partiesrR rW r r )r r resultsr mrU s r multipassz_TestBarrier.multipassl sk OOq A AJ d # LLN AJ d # LLN
" s & A21A2c | j | j g}| j | j | j ||f y r )r r r r )rp passesr s r test_barrierz_TestBarrier.test_barrier} s@ >>#T^^%56 $,,)HIr c & | j d S r{ )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 8 | j }| j | j | j |f t | j
D cg c] }|j
}}| j |j d d t | y c c}w r )
r r r r rR rw r rk countr# )rp r" rU r s r test_wait_returnz _TestBarrier.test_wait_return sz
11DLL%3HI(-dff
61599;66 q)1-E 7s Bc L |j t | dk7 rt y r )r r r3 )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 )N)r r )r r rw r r r
rk r )rp r r s r test_actionz_TestBarrier.test_action s_ ..",,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 rw r3 rW r BrokenBarrierErrorr )r r results1results2rU s r
_test_abort_fz_TestBarrier._test_abort_f sn ACEE1H}"" LLN OOD !++ " OOD ! MMO s A A $B
2B
B
c h | j }| j }| j | j | j ||f | j t | d | j t | | j dz
| j | j j y r ) r r r r rk r rw 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 rt T) r rw n_waitingr r
resetrW r r )r r r r results3rU 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 r )r r r r rk r rw )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 rw r3 rW r r r r )r r barrier2r r r rU 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 r )r r rw 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 rw r r
r r rW r r r rU 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 r )r r r( r rk r r )rp r s r r4 z_TestBarrier.test_timeout sR .." -- 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 rw r r
r r rW 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 )Nr r )r rw r r r+ rk r r )rp r r s r test_default_timeoutz!_TestBarrier.test_default_timeout# s^ ,,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 )rR r r )r r r connr^ rU 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 rY r rR rw r r2 r r rb r rk r )rp r r^ r1 r jr rU 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 rw r r r r r r r r r r r r
r r r r r r" r$ r( r4 r+ r- r/ r2 r6 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 )rU 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 rp )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 ) rF RawValuer rE rk r r r r r r ) rp rawcoder r rG rH rI 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)rL )rN 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 )NrU r r^ Fget_lockget_objnavalue)
r rT rU rY rk r r6 rl rD rK )
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 rF r r r rN rQ rb rZ r r r8 r8 L sW "M eCj%*%
LC
.&"3r r8 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 )rR r )r seqrU 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? rU r r r )r r r ra ra r r T) RawArrayArrayrk r r arrayr r r r r )rp rL rf 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 )Nr5 r rU r )rR rk rk r r )rp sizer rm 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 rP )rn 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 )NrU r5 rS FrT rU notalock) rk r rR rT rU rY rk r r6 rl rD rj )
rp arr1rX rY arr2r[ r\ r^ arr3r^ r_ r` ra 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 rx r< rn rq rs ry rZ r r rd rd s "M X__Ud]$67, 8,0 X__Ud]$67 8 X__Ud]$67" 8" X__Ud]$673 83r rd 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 ) Nr5 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 rR rk extendrW )rp r r r9 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 )Nr5 r( r )r rR 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 rR rk popr rW )rp _ir innerrU 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.0rU s r <genexpr>z,_TestContainers.test_dict.<locals>.<genexpr>+ s 'ECF 'Es )
dictr rR r rk r sortedkeysrG r )rp r9 indicesrU 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 rR r r rk r rl r3 r )rp r9 r rU 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 )ferretshamstersr5 r )waterfeed)petssuppliesr r r blanketsr r r r r r marmotsX c rA r )r rk r r r r )rp r r r9 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 rW 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 r6 )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 rR )totalwhenrU 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 )Nr5 r( r chunksize)r maprk r r rR )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 )Nr5 r~ rA r( r r r )r starmapr rE rR 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 rE rR 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 rR 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 rH rW 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 pickler2 r s r r z5_TestPool.test_map_unplicklable.<locals>.A.__reduce__ s
"?33r Nr9 rZ r r Ar s
4r r r5 ) r r r r; rl r3 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 r5 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 Nr5 r4 r( r ) r imapr r rR rk r r rl
StopIterationr rp r rU 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 r5 r r r r r ra )
r r r r r r r rl r r rR 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 rR 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 r5 r r r r )r r r r r r r rl r r r r rR r rm r )rp r expected_valuesrU 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
rR r r| r
assertLessr )rp rU rX r s r rA 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 rN 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 r5 r ) r r rR r r r rk r r rl rE )rp LrU rY 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 r2 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 rn r r3 rk rQ __cause__r r RemoteTracebackrm tbr< r r= ry
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 )NrR r2 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 r3 r r7 r rN 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 )Nr5 c 3 * K | ] } |
y wr rZ )r ro s r r z3_TestPool.test_release_task_refs.<locals>.<genexpr>
s 1bRT 1s r )rR r rj rk r r r rl rm r r
rM rk rc r )rp rU 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 rE r z%unclosed running multiprocessing pool)r r r r r r r RUN_stater
check_warningsResourceWarningr
gc_collectrF 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 rA r$ r( r* r5 r7 r9 r= rC rG rN
__classcell__r s @r r r s =
; ??
: 8)L 54< < 6 54H".H
+
? $L " "<(
7 !r r c t d )Nkey)KeyErrorrZ r r raisingrT 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_resultrY 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 r2
scratchpads r errbackz@_TestPoolWorkerErrors.test_async_error_callback.<locals>.errback s JqMr r r ) r r r rT rl rS r r r r r )rp r r` 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 r` z?_TestPoolWorkerErrors.test_unpickleable_result.<locals>.errback/ s #
1
r ra )multiprocessing.poolrd r r rR r rY rl r r r assertIsNotNoner2 r r r )rp rd r iterationr` 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 rb rj 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 r5 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 rR rW r r enumerater _repopulate_poolallr r
rM r r! r r r )
rp r r origworkerpidsr rU r5 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 rn r g333333?) r r rR rW r r r r rt rk r )rp r r rU r5 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 rn )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 cmdrg 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 rz r| r r rZ r r rl rl = s #M: 0@
r rl ) 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{ )rR )rU 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 r7 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 r7 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 r5 )r r r r6 rk r rl rE r r r r r rR ) rp r rR barr r+ foo_methods bar_methodsrU 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 Zy) QueueManagerNr rZ r r r r s .r r r c e Zd Zy)
QueueManager2Nr 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 rG 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 rb r r r r r r r r rk r rX 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 rG rX 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 r6 r rb 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 r1 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 r5 rU ra r r r r z( z expected BufferTooShort, got %sFrA r. Xi )(r r r r r r rl r rR r rk r filenorH r r r r r recv_bytes_intoitemsize bytearrayri r BufferTooShortrQ r| r r r r
r r
r r readablewritablerl EOFErrorr )rp r1 r r rf r longmsgrm bufferrY 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 r1 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 wrX )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 ) rR r rB dup2r r recv_handlemsvcrtopen_osfhandler r+ r )r r1 datacreate_dummy_fdsrU 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 rb r r r r r r
get_osfhandler send_handler r rk r )rp r1 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 rb r r r r r rR MAXFDr ri rB r r r r r r rk r )rp r1 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 r1 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 r3 r r r rp r1 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 rx ry rz r r6 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)
connectionfamiliesListenerrb 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 r9 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 clientr9 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_supportedr2 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( r. r r )r r r1 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 r/ rk r r r )rp r' r r r1 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
r/ rk r r r )rp r r r1 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* r. r r/ 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 r8 r: r> rZ r r r5 r5
s( ,M
r r5 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 r1 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 rs ) r r rF r rR r r rk r )rp rE r r r r rU 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 rM 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 )NrH rI 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 rH r& TrI rQ )r rk r r rR 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 rB r rF rK rM rO rR rT rZ r r r@ r@
sW ,M)
)
r r@ 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 rX r r r )r rX 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 r/ r socket
create_serverr r getsocknamer )r r1 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( r. r r r rZ r sendall)r r1 r r r1 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 ra r r r rk r r rW 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 r1 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 rl foobar foobarfoobar)
r r rm r r r r rk r r )rp r1 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^ ra rj rm rq rZ r r rV rV sb #M; ; $ ,\ r rV 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 )rv r r r ru r r rx 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 rp r r r4 freeoccupiedc 3 4 K | ] }|j y wr rp )r arenas r r z&_TestHeap.test_heap.<locals>.<genexpr> s F Fs r ) r r r ru _DISCARD_FREE_SPACE_LARGER_THANrR rH randomlognormvariaterW r randranger r _len_to_seqrG _arenasindex_allocated_blocksr rk sumsortrp shuffler _n_frees
_n_mallocs_pending_free_blocks)rp
iterations maxblocksblocksr rU rp r rv 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 )Nr5 r{ r ) rl isenabledenablerb disable
get_threshold
set_thresholdrR r r r buddy)rp
thresholdsrU 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 rO rP s @r rs rs s "MO >3@r rs 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 rA rB r s r r z_TestSharedCTypes.setUp rC 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 rp )r r> r? rR r )r r> r? r rR rm stringrU 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 )NrU r rS gUUUUUU?r< r r r9 r5 r r r r T gUUUUUU?r= r @
hellohello)r r= r> r rk r rR r r r r r r r rk r r> r? )
rp r^ r> r? r rR rm r r rU 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 )NTrS )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 rR 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 SharedMemoryri 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 createrp rW 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 rb r rk r+ r2 rp r ri 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 rb 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)rR pickleHIGHEST_PROTOCOLr r r rb r ri 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 )
rR r r r r r ri 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 rb r r r r+ r r r rk r ri 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
ShareableListrR rB rC r r r7 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 r5 r r r+ r1 howdy)r r r rl rE r r rR r r shmr+ rk r r2 ri r ry rz r )rp smm1rU lolr5 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( NTrW r r r r
z8s8sdqxxxxxx?xxxxxxxx?qignore100r( r r TrW somera z8s8sdq8sxxxxxxx?qzexceeds available storagez far too manyu encodésr r u encodéess 123456789s adiostest03_duplicater M rA ip r any)r r rb r r rm r+ rn r rl
IndexError_get_packing_formatrk r r warningscatch_warnings simplefilterrE r r rS 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 r5 r rA r~ changedra newvaluer i )rR r r r r r rb 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 r5 r )
rR r r r r r r r r r rl r r )rp r r r0 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)
subprocessPopenry 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 rL r r r r r r r r rF rx rB r+ r r r r+ r4 r6 rC 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 )rl rm r r rG updaterH 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 rM F r r )r r )r )r )d10r )rQ exitpriority)d01r )d02)d03)r i)STOPi)
r; r Finalizer rl rm _exit_functionr rB _exit) r r1 r r r close_br rO rQ rR rS 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 TrT )r r rO rS rR rQ r ) r r rY r r r r r rk )rp r1 r r r" rX 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( )rP )rk r rU 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 ra } s
Mr r Fc sCt j t j dz t j sBy y # t
$ r } | Y d } ~ d } ~ ww xY wrD )r r
r r _run_finalizersrh )r r2 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)Nr5 r )rR r getrandbitsrh r )r9 rU r r r2 rf 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; ry getswitchintervalrl r setswitchintervalr r r r
start_threadsr r
rm )
rp rg rj old_interval
old_thresholdr r r^ r2 rf 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 rY r[ r r rp rZ r r rE rE 7 sM "M)>
% %N N W u%4 &4r rE 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 rW )rp rt 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~ ry rz r r" r< r. r} r r6 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 rr rr s r rr 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 r1 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 rD )r r
rB rC r7 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 r7 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 r6 r7 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 rx 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 rp 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}rc 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< rN 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 rL )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 rW 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 rN s r test_pool_in_processz/TestStdinBadfiledescriptor.test_pool_in_process s$ # #? ; r c t j }t | j d t j
fd }j
y )NrR 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 )Nr5 r. )rR r r
r r rB r r )r r slowrU 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 rU r rx s r r z%TestWait.test_wait.<locals>.<genexpr>' s% GGA1aee*G*Gs "r5 )multiprocessing.connectionr rR r r r r r r r rW rb r r r r r r rk ) rp r r readersmessagesrU r' r r r rY rx 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 )Nr5 r. %s
rc ) rZ r rR r r
r r` r r )r r r r rU 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 r5 rc r )r r rZ r[ r r r\ rR r r r r r rW rb r r/ r r r r rG rk )rp r r r r r rx dicrU r r' r r rY 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 rG )r r s r test_wait_slowzTestWait.test_wait_slowW s t r c & | j d y rG )r r s r test_wait_socket_slowz TestWait.test_wait_socket_slowZ s d#r rq 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 rY r r r r r3 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 rj 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 )rT r s r r z>TestWait.test_wait_integer.<locals>.<lambda>.<locals>.<lambda> s
BqE r )rR )r )r s r r z,TestWait.test_wait_integer.<locals>.<lambda> s
F1/ : r r r r r r% )r r r rm r r r) r r ra rH r rZ r r rk r" r; r r r ) rp r rY sorted_rj r r r r r r3 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) r. r0 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.piper4 r s r test_invalid_family_win32z+TestInvalidFamily.test_invalid_family_win32 s>
z
* B & & / /0@ A B B Br6 N) ru rv rw rF rx r r5 r r8 rZ r r r2 r2 sI X__U 01= 2= X BCB DBr r2 c 2 e Zd Zed Zed Zd Zy) TestFlagsc T |j t t j y r )r r ry flagsr r1 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 rN r r r> r# r$ DeprecationWarningr r r r r ry r< printr ) r rS rA 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()r8 z-Sz-Or rc )
rA r rP r: check_outputry r r r? rk )rp rA progr child_flagsrE s r
test_flagszTestFlags.test_flags sz
&&5&F&F&H%K1
N
&&
^^T4tT :<(,
4;;w3G(H% % &67r N)ru rv rw r r> rF rL 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( r. )r childr r1 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 )rZ getdefaulttimeoutsetdefaulttimeoutr r r( r* r rQ r r r rk r r/ r& )rp old_timeoutparentrP r r r1 s r r4 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 rQ r4 rZ r r rN rN s 2r rN 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 ru rv r< r r assert_python_failurerk rm r r )rp rv r+ rg 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 rY rY s
'r rY 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 rP r r r& r r r _afterfork_registry)r r r1 r s r rP 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 r` r rP 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 rP 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 )Nrp )r rZ detachrW 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 rZ rS 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 )rZ fromfdrS rn r r rh )r r1 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 rl r rq r r r r& rP rn 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 rl r r rq ru rZ r r rg rg ; s% $ :r rg 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 r4 z-TestIgnoreEINTR._test_ignore.<locals>.handler r_ r ready x)r7 r r r r
CONN_MAX_SIZE)r r1 r4 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 rC r r7 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 rz s r r4 z6TestIgnoreEINTR._test_ignore_listener.<locals>.handler r_ r welcome)r7 r r r( r* r r r/ )r r1 r4 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 rC r r7 r r( r. rk r )rp r1 r r r r1 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 r6 r7 r r r rZ r r rw rw } s --w/D/DEM2 2 X35GH I, X35GH Ir rw 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 rN rE rk rP rn 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 rN rE rF rG rS 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 rN r r ru lowerr r r r2 )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_methodsry rz 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 ru rv r< r r r r? r rC ri )rp r+ rg 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 rN r r r# rS r3 r r r )rp process_methodr" process_ctxr rB 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 rQ )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 rW 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 rx ry rz 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, noopr8 r )r r, )pass_fdsr r T)r rc 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; ry r r r< r r r= r r? r- r r r r@ r r rm r ENOENTEINVALr r r )rp r r, r' r r r name1name2rB r r rq rY 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 rC r7 rD r wait_processr# r$ r% r r r
r rN rm rZ r[ rj rk rl rm r rk r r
issubclassr@ UserWarningrn r )
rp r
should_dier r rs all_warnrj ro 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 rC )r r7 r r s r test_resource_tracker_sigintz0TestResourceTracker.test_resource_tracker_sigint s ))&--?r c D | j t j d y rC )r r7 r? r s r test_resource_tracker_sigtermz1TestResourceTracker.test_resource_tracker_sigterm s ))&..%@r c D | j t j d y rG )r r7 rD 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 )r1 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 rL 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 rc 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 rc 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 rp 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 rp 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 rW )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 rr )r r% s r r zITestPoolNotLeakOnFailure.test_release_unused_processes.<locals>.<genexpr>: s Cw "Crs ) rS 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 Z ej j
Zd Zd Ze d Z
e
Z d Z d Z
e d Zd Ze d Zd#d Ze d
Zd#d Ze d Zd$d
Zd Ze d Zd Ze d Zd Ze d Zd 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")&TestSyncManagerTypesc 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 r@ 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 Nrt )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 rc r r r rp rA s r r z TestSyncManagerTypes.test_event s< LL ((!, u
r c $ |j y r rZ 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 r3 rp lnamerA s r r_ z TestSyncManagerTypes.test_lock sF (GDLL% ( * + , 2r c D |j |j y r rZ 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 rb z TestSyncManagerTypes.test_rlock s+ (GDLL% ( * ((!,r c $ |j y r r r s r rk z$TestSyncManagerTypes._test_semaphore r r c t | j | }| j | j | |j y r )r r r rk r[ )rp snamerA s r rn z#TestSyncManagerTypes.test_semaphore s4 (GDLL% ( * ,,a0 r c ( | j d y )Nrq )r# )rn r s r rr 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 rX r c t | j | d }|j d |j d | j | j | y )Nr r r )r r r r r1 )rp qnamerA s r
test_queuez TestSyncManagerTypes.test_queue sC (GDLL% ( + a a ((!,r c & | j d y )Nr% )r4 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 rW r r; rg 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 rR r )rR r )rF r8 rk r r assertListEqualr r r rG 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 rR r )r r r rC rg 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 r8 rk r r rc rB s r _test_valuez TestSyncManagerTypes._test_value sE " A& A&
r c | j j dd }| j | j | | j |j
d | j |j
d y )NrU r r )r r r rF rk r r r s r rN 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 r8 rk r r> r rB s r _test_arrayz TestSyncManagerTypes._test_array sd " Q# Q# S1% T#YA/r c x | j j dddg }| j | j | y )NrU r r )r rk r rI r s r rn z TestSyncManagerTypes.test_array s0 LL sQF + ((!,r c t j }|j |j d |j |j d y r )rF r8 rk r> r? rB s r _test_namespacez$TestSyncManagerTypes._test_namespace s8 " " "r c | j j }d|_ d|_ | j | j
| y r )r r r> r? r rL r s r r z#TestSyncManagerTypes.test_namespace& s6 LL " " $ ,,a0r Nrd )rm )r )*ru rv rw r r r r r r r r r r r r r r r_ r rb rk rn rr r& r( r* r r- r/ r1 r4 r6 r; r rC r rF rN rI rn rL 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 rb r r r+ textwrapdedentr r r r? )rp r r rg 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[ rT rZ r r rO rO - s !787 97r rO 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 rQ )r r rk r r? )rp rg 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 rV rV G s" F
!!<=7 >7r rV 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 rM rc r r% rb rc 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 r` r` d s( 4 4 r r` 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( rL r r r r r r r r% rY ra rm rq r r r r rk rK rj 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 r@ r r r r r
rl rm 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% rY ra rm rq r r r r rk r r r r r r r rO rP s @r ri ri 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 ri 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( rL r r r r r r% rY ra rm rq r r r r rk rZ r r rr rr 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 rr 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 Tempry s r rz r r c e Zd Zyrx r rZ r r rz 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% _cleanuprb r r rP rj rE rF rG ry rz r ra r rJ r get_temp_dirr r r )r^ rc 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 re r rf r )r< r rM r rj rc r% rb r r
r r r
r _cleanup_tests)
need_sleepr r rc 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 r8 r requires_hashdigestru rw rv r; ) remote_globsrS only_type
exclude_typesrv local_globs ALL_TYPESr+ basetype_newnamerv rz r r rc 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 rN r r ztest_semlock_subclass-r r r5 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 rC )rF
unittest.mockr" r rR r r r ry rB rl r rW r7 rl rZ r r r: r ro r r rj 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.managersrf 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 rM r r
r r r r r r
HAVE_GETVALUErz r r7 rC r r ctypesr; r< r= r> r; rJ r[ r8 r] r| r r r r r r r r r r rV rg ru r r r r r r r8 rd r{ r r r r r rE r r r rT rY r[ rl r r r r r r r r r r r r r r r r r r r r r$ r5 r@ r rV rs r r r rE rr r r r r r r r r r r r r r r r2 r: rN rY r^ rg rw r rx r r r r rO rV r` r ri rr r r6 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_;:_;>` ` `
`'&`'