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