�
N��ac	@s�dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZdd
lZdd
lZdd
lZdd
l	Z	dd
l
Z
dd
lZdd
lZdd
l
ZddlmZ
ddlmZ
ejd�
Zdd
lZejd�

dd
lZdd
lZdd
lZdd
lZdd
lZddlmZ
yddlmZ
eZWnek
ro



eZn
Xy ddl m!Z!m"Z"
eZ#Wnek
r�



eZ#n
Xydd
l$Z$Wnek
r�



d
Z$n
Xe&Z'ej(Z)d	Z*eZ+e+rd�\Z,Z-Z.nd�\Z,Z-Z.e/ed
e�Z0ej1dkZ2yej3d�
Z4Wn



dZ4n
Xy ddl5m6Z6m7Z7m8Z8
Wn!ek
r�


e9Z6d
Z7Z8n
Xd�Z:de9f
d��YZ;de9f
d��YZ<d�Z=de9f
d��YZ>de<f
d��YZ?dej@f
d��YZAde<f
d��YZBd �ZCd!�ZDd"e<f
d#��YZEd$e<f
d%��YZFd&e<f
d'��YZGd(e<f
d)��YZHd*e<f
d+��YZId,e<f
d-��YZJd.e<f
d/��YZKd0e<f
d1��YZLd2d3�
ZMd4�ZNd5e9f
d6��YZOd7ePf
d8��YZQd9�ZRd:e<f
d;��YZSd<�ZTd=e<f
d>��YZUd?e<f
d@��YZVdAe<f
dB��YZWddClmXZXmYZYmZZZ
dDe9f
dE��YZ[dF�Z\dGeYf
dH��YZ]dIeXf
dJ��YZ^e^j_dKdLe[�


e^j_dMdLe[dNd��

e^j_dQdLe\dRe]�

dSe<f
dT��YZ`e
j
�ZadU�ZbdVeXf
dW��YZcecj_dXdLeb�


dYeXf
dZ��YZdedj_dX�

d[Zed\e<f
d]��YZfd^e<f
d_��YZge'd`�
Zhdae<f
db��YZidce<f
dd��YZjdee<f
df��YZkdge6f
dh��YZldie<f
dj��YZmdke<f
dl��YZndme<f
dn��YZodoe<f
dp��YZpdqe<f
dr��YZqdsejrf
dt��YZsdu�Ztdv�Zudwe9f
dx��YZveuevdydz�

Zwex�jyew�

d{e9f
d|��YZzeuezdyd}�

Z{ex�jye{�

d~e9f
d��YZ|eue|dyd��

Z}ex�jye}�

d�ejrf
d���YZ~d��Zd�ejrf
d���YZ�d��Z�d��Z�d��Z�d��Z�d�e9f
d���YZ�d�ejrf
d���YZ�d�ejrf
d���YZ�d�ejrf
d���YZ�d�ejrf
d���YZ�d�ejrf
d���YZ�d�ejrf
d���YZ�e~ese�e�e�e�e�e�e�g	Z�d
d��
Z�d��Z�e�d�kr�e��
nd
S(�i����N(
tsupport(
tStringIOt_multiprocessingsmultiprocessing.synchronize(
tutil(
t	reduction(tValuetcopyg�������?g=
ףp=�?gffffff�?gffffff�?tHAVE_BROKEN_SEM_GETVALUEtwin32tSC_OPEN_MAXi
(t	Structuretc_inttc_doublecCsgd
}ytj
d�
}
Wnttfk
r3


dSX|
dksL|
|krPdStjd|�
�
dS(sACheck that the system supports enough semaphores to run the test.i
tSC_SEM_NSEMS_MAXNi����sHThe OS doesn't support enough semaphores to run the test (required: %d).(tostsysconftAttributeErrort
ValueErrortunittesttSkipTest(t	nsems_mintnsems((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytcheck_enough_semaphorescs





	
t
TimingWrapperc
BseZ
d�Zd
�ZRS(cCs|
|_d|_dS(
N(tfunctNonetelapsed(tselfR((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt__init__xs
	
c
Os;tj�}z|j
|
|�SWdtj�||_XdS(
N(ttimeRR(Rtargstkwdst
t((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt__call__|s


(t__name__t
__module__RR!(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRvs	tBaseTestCasecBs/eZ
dZd�Zd�Zd�ZeZRS(t	processestmanagertthreadscCs tr|j
|
|d
�
ndS(Ni
(t
CHECK_TIMINGStassertAlmostEqual(Rt
at
b((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytassertTimingAlmostEqual�s

cGs8y||�}Wntk
r#


nX|j
|
|�SdS(
N(tNotImplementedErrortassertEqual(RtvalueRRtres((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytassertReturnsIfImplemented�s





c
Gstd
�
�
dS(Ns#shouldn't try to pickle a test case(
R-(RR((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
__reduce__�s
(R%R&R'(R"R#t
ALLOWED_TYPESR,R1R2t
__reduce_ex__(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR$�s
		
	c

Csjy|j�SWnUt
k
re


y|jSWqft
k
ra


y|jSWqbt
k
r]


t�
qbXqfXn
XdS(
N(t	get_valueRt_Semaphore__valuet_valueR-(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR5�s












t
DummyCallablec
BseZ
d�ZRS(
cCs&t|t
�st�
|
jd
�

dS(Ni(t
isinstanceR8tAssertionErrortput(Rt
qt
c((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR!�s

(R"R#R!(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR8�s
t_TestProcesscBs�eZ
dZd�Zed��
Zd�Zed��
Zd�Zd�Z	d�Z
ed	��
Zd
�Zed��
Z
d�Zd
�ZRS(R%R'c
Cs�|jd
kr+|j
dj|j�
�

n|j�}
|
j}|j|
j��

|j|
j�

|j|t	�
|jt
|�
dk�

|j|
jt
j��
|j|
jd�
dS(NR'stest not appropriate for {}i(tTYPEtskipTesttformattcurrent_processtauthkeyt
assertTruetis_alivetdaemontassertIsInstancetbytestlenR.tidentRtgetpidtexitcodeR(RtcurrentRC((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_current�s


	




cOsr|j�}|
j
|�

|
j
|�

|
j
|j�

|jd
krn|
j
t|j�
�

|
j
|j�

ndS(NR'(RBR;tnameR?RHRCtpid(tclsR<RRRM((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_test�s







c
	Cs<|jd
�
}
|j
�}|
d
df}idd6dd6}d}|jd|jd	|d
|d|�}t|_|j�}|jdkr�|j|j	|j	�
n|j|j
�t�
|j|jt�
|j||j
��
|jt|j
��
tk�

|j|jd�
|j�
|j|jd�
|j|j
�t�
|j||j
��
|j|
j�|d
�
|j|
j�|�
|j|
j�|j�
|jdkr�
|j|
j�|j	�
|j|
j�|j�
n|j�
|j|jd
�
|j|j
�t�
|j||j
��
dS(Ni
iithellogR���Q@tbyetSomeProcessttargetRtkwargsROR'i(tQueuetEventtProcessRRtTrueRFRBR?R.RCREtFalsetassertNotIntactive_childrenRDttypetlistRLRtstarttassertIntgetRORPtjoin(RR<t
eRRWROt
pRM((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_process�s<





	
	

















c

Cstj
d
�

dS(Ni�(Rtsleep(
RQ((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_test_terminate�sc
Cs
|jd
kr+|j
dj|j�
�

n|jd|j�
}
t|
_|
j�
|j|
j	�t�
|j
|
|j��
|j|
jd�
|
j�
t|
j�
}|j|�d�
|j|jd�
|j|
j	�t�
|j|
|j��
|
j�
dS(NR'stest not appropriate for {}RVg(R?R@RARZRiR[RFRaR.RERbR^RLRt	terminateRRdR,RR\R](RRfRd((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_terminate�s


	







c
CsZytj
�}
Wntk
r)


d
}
n
X|jt|
�
tk�

|j|
d
k�

dS(Ni
(tmultiprocessingt	cpu_countR-RDR_tint(Rtcpus((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_cpu_count
s







c
Cs�|jt
|j��
t�
|jd
tjdtf
�}
|j|
|j��
t	|
_
|
j�
|j|
|j��
|
j
�
|j|
|j��
dS(NRVR(R.R_R^R`RZRRhtDELTAR]R[RFRaRbRd(RRf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_active_children!
s

	




cCs�d
dlm
}
|
j|�

t|�
dkr�xStd�
D]B}|jd|jd|
||g
f�}|j�
|j�
q<WndS(Ni����(
tforkingiRVR(	RlRstsendRItrangeRZt_test_recursionRaRd(RQtwconntidRst
iRf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRv.
s




	


c
Cs�|jd
t
�
\}
}|j|g�
tjt�

g}x#|
j�r`|j|
j��

q>Wgdg
ddgddgdg
ddgddgg}|j	||�
dS(Ntduplexii
(
tPipeR\RvRRhRqtpolltappendtrecvR.(RtrconnRwtresulttexpected((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_recursion:
s







	
	

	
cCs#t|d
�t
_t
j|
�

dS(Nt
w(topentsyststderrtexit(RQtreasonttestfn((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_test_sys_exitN
s
c
	Csp
|jd
kr+|j
dj|j�
�

ntj}
|jtj|
�
x�dddgdfdfD]�\}}|jd|jd||
f�}t	|_
|j�
|jd	�

|j
|j|�
t|
d
��)}|j
|j�j�t|�
�
WdQXqcWxht	tdfD]W}|jdtjd|f
�}t	|_
|j�
|jd	�

|j
|j|�
q
WdS(
NR'stest not appropriate for {}i
iisignore thisRVRit
ri(signore thisi
(R?R@RARtTESTFNt
addCleanuptunlinkRZR�R[RFRaRdR.RLR�treadtrstriptstrR\R�R�(RR�R�tcodeRft
f((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_sys_exitS
s$
	
(
!
	





,

	




c
Cs�t�}
t
j|
�
}|j�}|jd
|
d||
f�}~
|j�
|j�
|j|�d�
|j	|j
�d�
dS(NRVRi(R8tweakreftrefRXRZRaRdtassertIsRR.Rc(RR=twrR<Rf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_lose_target_refl
s
	









(R%R'(R"R#R3RNtclassmethodRRRgRiRkRpRrRvR�R�R�R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR>�s	
	'			
		t_UpperCaserc
Bs,eZ
d�Zd
�Zd�Zd�ZRS(c

Cs,tj
j|�

tj�\|_|_dS(
N(RlRZRR{t
child_conntparent_conn(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR~
s

c
CsT|jj
�
x3t|jjd�D]}
|jj|
j��

q#W|jj
�
dS(
N(R�tclosetiterR�R~RRttupper(Rt
s((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytrun�
s




cCs5t|
�
t
kst�
|jj|
�

|jj�S(
N(R_R�R:R�RtR~(RR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytsubmit�
s


c

Cs.|jj
d�

|jj�
|jj�
dS(
N(R�RtRR�R�(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytstop�
s



(R"R#RR�R�R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�|
s			t_TestSubclassingProcessc
BseZ
dZd
�ZRS(R%c
Csft�}
t
|
_|
j�
|j|
jd
�
d�
|j|
jd�
d�
|
j�
|
j�
dS(NRStHELLOtworldtWORLD(R�R[RFRaR.R�R�Rd(Rt
uppercaser((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_subclassing�
s
	
	






(
R%(R"R#R3R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��
sc

Cs-t|d
�r|j
�S|j�dkSdS(Ntemptyi(thasattrR�tqsize(
R<((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytqueue_empty�
s


cCs-t|d
�r|j
�S|j�|
kSdS(Ntfull(R�R�R�(R<tmaxsize((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
queue_full�
s


t
_TestQueuecBs�eZ
ed��
Zd
�Zed��
Zd�Zed��
Zd�Zd�Z	ed��
Z
d�Zd	�Zd
�Z
RS(cCs9|j�
xt
d
�
D]}|
j�
qW|j�
dS(Ni(twaitRuRctset(RQtqueuetchild_can_starttparent_can_continueRy((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt	_test_put�
s



c
Cs�d
}
|jd|
�
}|j
�}|j
�}|jd|jd|||f�}t|_|j�
|jt|�
t�
|jt	||
�t
�
|jd�

|jdt�
|jdtd�
|jdt
�
|jd	t
d�
|j
d
�

tjt�

|jt|�
t
�
|jt	||
�t�
t|j�
}t|j
�
}|jtj|d
t
�
|j|jd�
|jtj|d
t
d�
|j|jd�
|jtj|d
�
|j|jd�
|jtj|d
tt�
|j|jt�
|jtj|d
t
t�
|j|jd�
|jtj|d
tdt�

|j|jt�
|j�
|j�
|jt|�
t�
|jt	||
�t
�
|j�
dS(
NiR�RVRi
iiiiiittimeout(RXRYRZR�R[RFRaR.R�R�R\R;Rt
put_nowaitRRhRqRtassertRaisestFullR,RtTIMEOUT1tTIMEOUT2tTIMEOUT3R�R�Rd(RtMAXSIZER�R�R�tprocR;R�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_put�
sN



	
	
	






















cCsL|j�
|
j
d
�

|
j
d�

|
j
d�

|
j
d�

|j�
dS(Niiii(R�R;R�(RQR�R�R�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt	_test_get�
s








c
CsP|j�}
|j
�}|j
�}|jd
|jd|
||f�}t|_|j�
|jt|
�
t�
|j	�
|j
�
tjt
�

|jt|
�
t�
|j|
jtd�d�
|j|
jt�
d�
|j|
jdd�
d�
|j|
j�d�
|jt|
�
t�
t|
j�
}t|
j�
}|jtj|t�
|j|jd	�
|jtj|td�
|j|jd	�
|jtj|�
|j|jd	�
|jtj|tt�
|j|jt�
|jtj|tt�
|j|jd	�
|jtj|dt�

|j|jt�
|j�
dS(
NRVRiiR�i
iii(RXRYRZR�R[RFRaR.R�R�R�RRhRqR\RcRt
get_nowaitRR�tEmptyR,RR�R�R�Rd(RR�R�R�R�RcR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_get�
sB


	
	
	
















cCs+x$td
d�D]}|
j
|�

qWdS(Ni
i(RuR;(RQR�Ry((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
_test_fork2s
c
Cs�|j�}
x!t
d
�
D]}|
j|�

qWtjt�

|jd|jd|
f
�}t|_	|j
�
x*t
d�
D]}|j|
j�|�
q{W|j
tj|
jt�
|j�
dS(Ni
RVRi(RXRuR;RRhRqRZR�R[RFRaR.RcR�R�R\Rd(RR�RyRf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt	test_fork:s


	



c
Cs�|j�}
y|j
|
j�d
�
Wntk
rF


|jd�

n
X|
jd�

|j
|
j�d�
|
jd�

|j
|
j�d�
|
j�
|j
|
j�d�
|
j�
|j
|
j�d
�
dS(Nisqsize method not implementedi
ii(RXR.R�R-R@R;Rc(RR<((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_qsizeUs

















cCs8x1t|
j
d�D]}tjt�

|
j�
qWdS(
N(R�RcRRRhRqt	task_done(RQR<tobj((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_test_task_doneds


c
Cs

|j�}
t
jd	kr;t|
d�r;|jd�

ngtd�
D]$}|jd|jd|
f
�^qH}x!|D]}t|_	|j
�
qyWx!td�
D]}|
j|�

q�W|
j�
x|D]}|
jd�

q�Wx|D]}|j�
q�WdS(
NiiR�s#requires 'queue.task_done()' methodiRVRi
(ii(t
JoinableQueueR�tversion_infoR�R@txrangeRZR�R[RFRaR;RdR(RR�RytworkersRf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_task_donejs


4

	






c
Cs�tj
���
d
}
t|
dd��}|jd�

WdQXtjtj��
�7
yt|
�

Wn!tj	k
r�


|j
d�

n
XWdQXWdQXdS(Ntimported_by_an_imported_modules.pyR�s�if 1:
                    import multiprocessing

                    q = multiprocessing.Queue()
                    q.put('knock knock')
                    q.get(timeout=3)
                    q.close()
                s?Probable regression on import lock contention; see Issue #22853(Rttemp_cwdR�twritet
DirsOnSysPathRtgetcwdt
__import__RXR�tfail(Rtmodule_nameR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_no_import_lock_contention�s









c
Cs�|jd
kr+|j
dj|j�
�

ndtf
d��Y}
tjj��G
|j�}|j|
��

|jt	�

|j
|jdd�
�

WdQXdS(NR%stest not appropriate for {}tNotSerializablec
BseZ
d�ZRS(
c


Ss
t�
dS(
N(
R(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR2�s
(R"R#R2(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��s
R�g�?(R?R@RAtobjectttestRtcaptured_stderrRXR;R[RDRc(RR�R<((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt"test_queue_feeder_donot_stop_onexc�s




(R"R#R�R�R�R�R�R�R�R�R�R�R�R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��
s	:
	4				t	_TestLockc
Bs#eZ
d�Zd
�Zd�ZRS(c
Csq|j�}
|j
|
j�t�
|j
|
jt�
t�
|j
|
j�d�
|jtt	j
f|
j�
dS(
N(tLockR.tacquireR[R\treleaseRR�Rt	threadingtThreadError(Rtlock((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt	test_lock�s





c
Cs�|j�}
|j
|
j�t�
|j
|
j�t�
|j
|
j�t�
|j
|
j�d�
|j
|
j�d�
|j
|
j�d�
|jttf|
j�
dS(
N(	tRLockR.R�R[R�RR�R:tRuntimeError(RR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_rlock�s







c

Cs|j��
WdQXdS(
N(
R�(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_lock_context�s


(R"R#R�R�R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��s		
t_TestSemaphorec
Bs,eZ
d�Zd
�Zd�Zd�ZRS(cCs�|jd
t
|
�
|j|
j�t�
|jdt
|
�
|j|
j�t�
|jdt
|
�
|j|
jt�
t�
|jdt
|
�
|j|
j�d�
|jdt
|
�
|j|
j�d�
|jd
t
|
�
dS(Nii
i(R1R5R.R�R[R\R�R(Rtsem((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_test_semaphore�s










c
Csr|jd
�
}
|j
|
�

|j|
j�d�
|jdt|
�
|j|
j�d�
|jdt|
�
dS(Niii(t	SemaphoreR�R.R�RR1R5(RR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_semaphore�s






c
Cs |jd
�
}
|j
|
�

dS(Ni(tBoundedSemaphoreR�(RR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_bounded_semaphore�s

c
Cs&
|jd
kr+|j
dj|j�
�

n|jd�
}
t|
j�
}|j|t�
t�
|j|j	d�
|j|td�t�
|j|j	d�
|j|tt�t�
|j|j	d�
|j|tt
�t�
|j|j	t
�
|j|dt�
t�
|j|j	t�
dS(NR%stest not appropriate for {}igR�(R?R@RAR�RR�R.R\R,RRR�R[R�R�(RR�R�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_timeout�s







(R"R#R�R�R�R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��s	
		t_TestConditioncBs>eZ
edd�
�
Zd
�Zd�Zd�Zd�ZRS(cCs9|
j�
|j
�
|
j|�

|j
�
|
j
�
dS(
N(R�R�R�(RQtcondtsleepingtwokenR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��s








cCss|jd
kroyI|
j
j�|
jj�}|j|d�
|j|
jj�d�
Wqotk
rk


qoXndS(NR%i(R?t_sleeping_countR5t_woken_countR.t_wait_semaphoreR-(RR�tsleepers((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytcheck_invariants







c
Csc
|j�}
|j
d
�
}|j
d
�
}|jd|jd|
||f�}t|_|j�
tjd|jd|
||f�}t|_|j�
|j	�
|j	�
t
jt�

|j
d
t|�
|
j	�
|
j�
|
j�
t
jt�

|j
dt|�
|
j	�
|
j�
|
j�
t
jt�

|j
dt|�
|j|
�

|j�
dS(NiRVRi
i(t	ConditionR�RZR�R[RFRaR�tThreadR�RRhRqR1R5tnotifyR�R�Rd(RR�R�R�Rf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_notify
s2


$
	

$
	






















c
	Csr|j�}
|j
d
�
}|j
d
�
}x�td�
D]z}|jd|jd|
||tf�}t|_|j�
t	j
d|jd|
||tf�}t|_|j�
q7Wxtd�
D]}|j�
q�Wxtd�
D]}|j�
q�W|j
d
t|�
|j|
�

x�td�
D]t}|jd|jd|
||f�}t|_|j�
t	j
d|jd|
||f�}t|_|j�
q$
Wxtd�
D]}|j�
q�
Wtjt�

|j
d
t|�
|
j�
|
j�
|
j�
xPtd�
D]B}yt|�
dkr'PnWntk
r<


Pn
Xtjt�

qW|j
dt|�
|j|
�

dS(NiiRVRii
(R�R�RuRZR�R�R[RFRaR�R�R�R�R1R5R�RRhRqt
notify_allR�R-(RR�R�R�RyRfR ((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_notify_all8sR





	



	





$
	

$
	
















c
Csb|j�}
t
|
j�
}|
j�
|t�
}|
j�
|j|d�
|j|j	t�
dS(
N(
R�RR�R�R�R�R.RR,R(RR�R�R0((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�ys








N(	R"R#R�RR�R�R
R
R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��s
		+	At
_TestEventcBs eZ
ed��
Zd
�ZRS(cCstj
t�

|
j�
dS(
N(RRhR�R�(RQtevent((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_test_event�s

c
CsD
|j�}
t
|
j�
}|j|
j�t�
|j|d
�
t�
|j|jd
�
|j|t�
t�
|j|jt�
|
j	�
|j|
j�t
�
|j|�t
�
|j|jd
�
|j|t�
t
�
|j|jd
�
|
j�
|jd|j
d|
f
�}t
|_|j�
|j|�t
�
dS(NgRVR(RYRR�R.tis_setR\R,RR�R�R[tclearRZR
RFRa(RR
R�Rf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_event�s$











	


(R"R#R�R
R
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR
�st
_TestValuecBskeZ
dZdddd
ed�
ed�
fgZd
�Zed��
Zed�
Z	d�Z
d�ZRS(R%Ryi�i�^t
dg
@g�t
hi���i�R=t
xt
yc

Csts|j
d
�

ndS(Ns%requires multiprocessing.sharedctypes(tHAS_SHAREDCTYPESR@(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytsetUp�s

cCs4x-t|
|j
�D]\}}|d
|_qWdS(Ni(tziptcodes_valuesR/(RQtvaluestsvtcv((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRR�s
c	Cs
|
r:g|jD]!\}}}|j
||�^q}n1g|jD]!\}}}|j||�^qD}x7t||j�D]#\}}|j|j|d
�
q~W|jd|jd|f
�}t|_	|j
�
|j�
x7t||j�D]#\}}|j|j|d�
q�WdS(Ni
RVRi(R
tRawValueRR
R.R/RZRRR[RFRaRd(	RtrawR�R/t
_R
R
R
R�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_value�s


1
.

	




c

Cs|jd
t
�

dS(NR
(R
R[(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_rawvalue�s
c

CsK
|jd
d�}
|
j
�}|
j�}|jd
ddd�
}|j
�}|j�}|j�}|jd
dd|�
}|j
�}	|j�}
|j||	�
|jd
ddt�
}|jt|d��

|jt|d��

|j	t
|jd
ddd�

|jd
d�}|jt|d��

|jt|d��

dS(NRyiR�tget_locktget_objtnavalue(RR
R
RR�R.R\tassertFalseR�R�RR
(
Rtval1tlock1tobj1tval2tlock2tobj2R�tval3tlock3tobj3tarr4tarr5((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_getobj_getlock�s$












(
R%(Ryi�i�^(R

g
@g�(R
i���i�(R"R#R3tlatinR
R
R�RRR\R
R
R)
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR	
�s


		t
_TestArraycBs�eZ
dZed
��
Zejed	kd�e	d�
�
Z
ejed	kd�d��
Zejed	kd�d��
Zejed	kd�d��
Z
ejed	kd�d��
ZRS(
R%cCs<x5td
t
|
�
�D]}|
|c|
|d
7<qWdS(Ni
(RuRI(RQtseqRy((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��s
srequires _ctypesc
CsY
d
dddddddd	d
g
}|
r?|jd|�}n|j
d|�}|jt|�
t|�
�
|j|d|d�
|jt|d
d!�
t|d
d!�
�
tjddd
ddg�|dd+|dd+|jt|�
|�
|j|�

|jd|jd|f
�}t|_	|j
�
|j�
|jt|�
|�
dS(Ni�iri�i5i�i�i$i�i�i?Ryiiii
iiRVR(tRawArraytArrayR.RIR`tarrayR�RZR[RFRaRd(RR
R,
tarrRf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_array�s$



*0

	



c
Cs�d
}
x�td�
D]w}|j
d|
�}|jt|�
|
�
|jt|�
dg
|
�
td
�
|(|jt|�
td
�
�
~qWdS(Ni
iRyi(RuR.
R.RIR`(RtsizeR
R0
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_array_from_sizes






c

Cs|jd
t
�

dS(NR
(R1
R[(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_rawarray&sc
CsT|jd
d�}
|j
t|
�
d�
|jd
d�}|j
t|�
d�
dS(NRyl

i
(R.
R.RIR-
(RR0
traw_arr((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_array_accepts_long*s


c

Cso
|jd
t
d�
�}
|
j�}|
j�}|jd
t
d�
dd�
}|j�}|j�}|j�}|jd
t
d�
d|�
}|j�}	|j�}
|j||	�
|jd
t
d�
dt�
}|jt	|d��

|jt	|d��

|j
t|jd
t
d�
dd�

|jd
t
d�
�}|jt	|d��

|jt	|d��

dS(NRyi
R�R
R
tnotalock(
R.
RuR
R
RR�R.R\R
R�R�RR-
(
Rtarr1R
R 
tarr2R"
R#
R�tarr3R%
R&
R'
R(
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_getobj_getlock_obj1s&










	


(
R%N(R"R#R3R�R�RtskipIfRRR\R1
R3
R4
R6
R;
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR+
�s
!!!t_TestContainersc
Bs;eZ
dZd
�Zd�Zd�Zd�Zd�ZRS(R&c
Cs�
|jt
d
�
�
}
|j|
t
d
�
�
|j�}|j|g�
|jt
d�
�

|j|t
d�
�
|j|dd�
|j|dd
!dddg�
|d9}|j|ddddddddddg
�
|j|ddgddddddddddddg�
|j|
t
d
�
�
|
|g}|j|�
}|j|dddddddd	d
dg
ddddddddddg
g�
|j|
g
�
}|
jd�

|j|dddddddd	d
ddgg
�
dS(
Ni
iiiiii
iiii	RS(R`RuR.textendR}(RR*R+R

ReR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt	test_listSs(




 

/>



I


c
Cs�|jt
d
�
�
}
t|
�
}|jt|�
t
d
�
�
|jt|�
g�
t|
�
}d|
d<|jt|�
d�
dS(Ni
idi(R`RuR�R.tnext(RR*tit((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_list_iterrs






c
Cs�|j�}
t
d
d�}x|D]}t|�
|
|<q"W|j|
j�td�|D�
�
�
|jt|
j��
|�
|jt|
j��
g|D]}t|�
^q��
|jt|
j��
g|D]}|t|�
f^q��
dS(NiAiFc
ss!|]}
|
t|
�
fV
qdS(
N(
tchr(t.0Ry((s5/usr/local/lib/python2.7/test/test_multiprocessing.pys	<genexpr>�s(	tdictRuRC
R.RtsortedtkeysR
titems(RR

tindicesRy((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt	test_dict|s





&

5
c
Cs�|j�}
t
d
d�}x|D]}t|�
|
|<q"Wt|
�
}|jt|�
|�
|jt|�
g�
t|
�
}|
j�
|jtt	|�
dS(NiAiF(
RE
RuRC
R�R.R`R
R�R�R@
(RR

RI
RyRA
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_dict_iter�s










c
Cs�|j�}
d
|
_
d|
_d|
_|j|
j
|
jfd�
|
`|jt|
�
d�
|jt|
d��

|jt|
d��

dS(NtBobtBuilderthiddensNamespace(name='Bob')ROtjob(RL
RM
(t	NamespaceRORO
t_hiddenR.R�RDR�(Rt
n((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_namespace�s

	
	
	




(
R&(R"R#R3R?
RB
RJ
RK
RS
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR=
Os		
	
	
gcCstj
|
�

||S(
N(RRh(R
R�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytsqr�s


c


Cs|S(
N((
R
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytidentity�s
t
CountedObjectc
Bs eZ
dZd
�Zd�ZRS(ic

Cs|jd
7_t
j|�
S(Ni
(tn_instancesR�t__new__(
RQ((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRX
�s

c

Cst|�
j
d
8_
dS(Ni
(R_RW
(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt__del__�s
(R"R#RW
RX
RY
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRV
�s
	tSayWhenErrorc
BseZ
RS((R"R#(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRZ
�sccs;x4t|�
D]&}||
kr.t
d
�
�
n|V
q
WdS(NsSomebody said when(RuRZ
(ttotaltwhenRy((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytexception_throwing_generator�s



t	_TestPoolc
Bs�eZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
d�Zd
�ZRS(c
Cs[|jj
}
|j|
td�td
�
�
|j|
tdi
dd6�tdd�
�
dS(NiiR
(
i((tpooltapplyR.RT
(Rtpapply((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_apply�s


c
Csr|jj
}
|j|
ttd
�
�t
ttd
�
��
|j|
ttd�
dd�
t
ttd�
��
dS(Ni
idt	chunksizei(R_
tmapR.RT
Ru(Rtpmap((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_map�s

.

c
Csx|jd
kr+|j
dj|j�
�

ndtf
d��Y}
|jt�
�"
|jjt|
�g
d�
WdQXdS(NR'stest not appropriate for {}t
Ac
BseZ
d�ZRS(
c

Sstd
�
�
dS(Ns
cannot pickle(
R�(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR2�s
(R"R#R2(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRg
�s
i
(	R?R@RAR�R�R�R_
Rd
RT
(RRg
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_map_unplicklable�s



c

CsQy)|jj
tgd
d�
jdt�

Wn!tjk
rL


|jd�

n
XdS(NRc
i
R�s2pool.map_async with chunksize stalled on null list(R_
t	map_asyncRT
RcR�RltTimeoutErrorR�(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_map_chunksize�s

)

c
CsT|jj
td
tf�}
t|
j�
}|j|�d�
|j|jt�
dS(Nii1(	R_
tapply_asyncRT
R�RRcR.R,R(RR0Rc((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_async�s



c
Cs^|jj
td
tdf�}
t|
j�
}|jtj|dt�

|j	|j
t�
dS(Nig�?R�(R_
Rl
RT
R�RRcR�RlRj
R,R(RR0Rc((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_async_timeout�s



c
Cs
|jj
ttd
�
�}
|jt|
�
tttd
�
��
|jj
ttd
�
�}
x.td
�
D] }|j|
j�||�
qhW|jt	|
j�
|jj
ttd�
dd�
}
x.td�
D] }|j|
j�||�
q�W|jt	|
j�
dS(Ni
i�Rc
id(
R_
timapRT
RuR.R`Rd
R@
R�t
StopIteration(RRA
Ry((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt	test_imap�s

%


!


c
Cs^
|jd
kr+|j
dj|j�
�

n|jjttdd�d�}
x.td�
D] }|jt	|
�
||�
qYW|j
t|
j	�
|jjttdd�d�}
x.td	�
D] }|jt	|
�
||�
q�W|j
t|
j	�
|jjttdd�d
�}
x.td
�
D] }|jt	|
�
||�
q#
W|j
t|
j	�
dS(NR&stest not appropriate for {}i
ii
iiiii(R?R@RAR_
Ro
RT
R]
RuR.R@
R�RZ
(RRA
Ry((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt#test_imap_handle_iterable_exception�s

!


!



!


c
Cs�|jj
ttd
�
�}
|jt|
�
tttd
�
��
|jj
ttd�
dd
�
}
|jt|
�
tttd�
��
dS(Nidi�Rc
(R_
timap_unorderedRT
RuR.RF
Rd
(RRA
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_imap_unordereds

%!
c
	CsG
|jd
kr+|j
dj|j�
�

n|jjttdd�d�}
tttd�
�}|j	t
�
�E
x=td�
D]/}t|
�
}|j||�
|j
|�

q~WWdQX|jjttdd�d�}
tttd�
�}|j	t
�
�E
x=td�
D]/}t|
�
}|j||�
|j
|�

q

WWdQXdS(	NR&stest not appropriate for {}i
ii
iii(R?R@RAR_
Rs
RT
R]
Rd
RuR�RZ
R@
Rbtremove(RRA
texpected_valuesRyR/((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt-test_imap_unordered_handle_iterable_exceptions(



	






	





c
Csl|jt
tjd
�
|jt
tjd�
tjd�
}
|jdt|
j�
�
|
j�
|
j�
dS(Ni����ii(	R�RRltPoolR.RIt_poolR�Rd(RRf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_make_pool%s





c
Cs}|jd
�
}
|
j
tjgtd�
D]}d^q(dd�
}|
j�
t|
j�
}|�
|j|j	dk�

dS(Nii'g�������?Rc
i
g�������?(
Rx
Ri
RRhRuRjRRdRDR(RRfRyR�Rd((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRk.s


.



c
Cs�|jd
�
}
|j
|
jtg�g�
|j
t|
jtg��
g�
|j
t|
jtg��
g�
|j
|
jtg�j�g�
|
j	�
|
j
�
dS(Ni
(Rx
R.Rd
RT
R`Ro
Rs
Ri
RcR�Rd(RRf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_empty_iterable8s
"
"
"

c
Cs�td
�t
d�
D�
�
}
td�|
D�
�
}|jjt|
�
~
tjt�

|jt	d�|D�
�
dh
�
|jtjd�
dS(Nc
ss|]}
t�V
qdS(
N(
RV
(RD
Ry((s5/usr/local/lib/python2.7/test/test_multiprocessing.pys	<genexpr>Gsi
c
ss|]}
tj
|
�
V
qdS(
N(R�R�(RD
t
o((s5/usr/local/lib/python2.7/test/test_multiprocessing.pys	<genexpr>Hsc
ss|]}
|
�V
qdS(
N((RD
R�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pys	<genexpr>Msi(
R`RuR_
Rd
RU
RRhRqR.R�RRV
RW
(Rtobjstrefs((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_release_task_refsDs




#(R"R#Rb
Rf
Rh
Rk
Rm
Rn
Rq
Rr
Rt
Rw
Rz
RkR{
R
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR^
�s			
										
	c
Csd
�S(Nc
Ssd
S(Ni*((((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt<lambda>Tt((((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytunpickleable_resultSs
t_TestPoolWorkerErrorsc
BseZ
dZd
�ZRS(R%c
Cspd
dlm
}

tjd�
}x6td�
D](}|jt�
}|j|
|j�
q,W|j	�
|j
�
dS(Ni����(
tMaybeEncodingErrorii(tmultiprocessing.poolR�
RlRx
RuRl
R�
R�RcR�Rd(RR�
Rft	iterationR0((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_unpickleable_resultYs





(
R%(R"R#R3R�
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
Vs
t_TestPoolWorkerLifetimec
Bs eZ
dZd
�Zd�ZRS(R%c

Cs�
tj
d
dd�

}
|jd
t|
j�
�
g|
jD]}|j^q8}g}x0td�
D]"}|j|
jt	|f
��

q`Wx6t
|�
D](\}}|j|j�t	|�
�
q�W|
j�
d}x;|r
t
d�|
jD�
�
r
|d8}tjt�

q�Wg|
jD]}|j^q
}	|jd|�
|jd|	�
|jt|�
t|	�
�
|
j�
|
j�
dS(Nitmaxtasksperchildi
idi2c
ss|]}
|
j�V
qdS(
N(
RE(RD
R�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pys	<genexpr>ysi
(RlRx
R.RIRy
RPRuR}Rl
RT
t	enumerateRct_repopulate_pooltallRRhRqR]RtassertNotEqualRF
R�Rd(
RRfR�torigworkerpidstresultsRyt
jR0t	countdowntfinalworkerpids((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_pool_worker_lifetimehs&




 
 

#







c
Cs�tj
d
dd�

}
g}x3td�
D]%}|j|
jt|df��

q(W|
j�
|
j�
x6t|�
D](\}}|j	|j
�t|�
�
qrWdS(NiR�
i
ig333333�?(RlRx
RuR}Rl
RT
R�RdR�
R.Rc(RRfR�
RyR�
R0((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt%test_pool_worker_lifetime_early_close�s


#




(
R%(R"R#R3R�
R�
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
es
	t_TestZZZNumberOfObjectsc
BseZ
dZd
�ZRS(R&c
Csnd
}
tj
�
tj�
|jj�}|jj�}||
krZ|jj�GH|GHn|j||
�
dS(Ni
(RlR^tgctcollectR&t_number_of_objectst_debug_infoR.(RtEXPECTED_NUMBERR~
t
debug_info((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_number_of_objects�s









(
R&(R"R#R3R�
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�s(tBaseManagert	BaseProxytRemoteErrortFooBarc
Bs#eZ
d�Zd
�Zd�ZRS(c


Csd
S(Nsf()((
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��s
c


Cs
t�
dS(
N(
R(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
g�s
c


Csd
S(Ns_h()((
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_h�s
(R"R#R�R�
R�
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�s
		c
cs$xtd
�
D]}||V
q
WdS(Ni
(
R�(
Ry((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytbaz�s

t
IteratorProxycBs)eZ
dZd�Zd�Zd�ZRS(R@
t__next__c


Cs|S(
N((
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt__iter__�s
c

Cs
|jd
�
S(NR@
(
t_callmethod(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR@
�s
c

Cs
|jd
�
S(NR�
(
R�
(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�s
(R@
R�
(R"R#t	_exposed_R�
R@
R�
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�s

		t	MyManagerc
BseZ
RS((R"R#(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�s
tFootcallabletBartexposedR�R�
R�
t	proxytypet_TestMyManagerc
BseZ
dZd
�ZRS(R&c
	Cs�
t�}
|
j
�
|
j�}|
j�}|
j�}gdD]}t||�r>|^q>}gdD]}t||�rf|^qf}|j|d
dg�
|j|d
dg�
|j|j�d�
|jt	|j
�
|j|jd
�
d�
|jt|jd�
|j|j�d�
|j|j
�d�
|j|jd
�
d�
|j|jd�
d�
|jt|�
gtd�
D]}||^q�
�
|
j�
dS(	NR�R�
R�
sf()s_h()i
(R�R�
R�
(R�R�
R�
(R�
RaR�
R�
R�
R�R.R�R�RR�
R�
R�
R�
R`Rutshutdown(	RR&tfootbarR�
ROtfoo_methodstbar_methodsRy((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_mymanager�s&
	



(
(






3(
R&(R"R#R3R�
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�sc
CstS(
N(
t_queue(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt	get_queue�s
tQueueManagerc
BseZ
dZRS(
s$manager class used by server process(R"R#t__doc__(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�s
R�
t
QueueManager2c
BseZ
dZRS(
s@manager class which specifies the same interface as QueueManager(R"R#R�
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�s
t	xmlrpclibt_TestRemoteManagercBsteZ
dZd
dedgZeZejrZej	d�
Z
eje
�

eje
�

ned��
Z
d�ZRS(R&shello worldg@s=\u043f\u0440\u0438\u0432\u0456\u0442 \u0441\u0432\u0456\u0442cCsKtd
|
d|dt
�}|j�
|j�}|jt|j�
�

dS(NtaddressRCt
serializer(R�
t
SERIALIZERtconnectR�
R;ttupleR
(RQR�
RCR&R�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_putters



c
Cs�tj
d
�
}
tdtjjdfd|
dt�}|j�
|jd|j	d|j
|
f�}t|_|j�
t
d|j
d|
dt�}|j�
|j�}|j|j�|j�
|jt|jtj�
~|j�
dS(Ni R�
iRCR�
RVR(RturandomR�
R�RtHOSTR�
RaRZR�
R�
R[RFR�
R�
R�
R.RcR�R�t	ExceptionR;RRhR�
(RRCR&Rftmanager2R�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_remotes

!
$
	





(
R&N(R"R#R3RR[R
R�Rthave_unicodet
utuvalueR}R�R�
R�
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
s

	


t_TestManagerRestartcBs eZ
ed��
Zd
�ZRS(cCsBtd
|
d|dt
�}|j�
|j�}|jd�

dS(NR�
RCR�
shello world(R�
R�
R�
R�
R;(RQR�
RCR&R�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
6s





c
Cs�tj
d
�
}
tdtjjdfd|
dt�}|j�}|j}|j	j
�
|j�
|jd|j
d|j|
f�}|j�
|j�
|j�}|j|j�d�
~|j�
td|d|
dt�}|j�
|j�
dS(	Ni R�
iRCR�
RVRshello world(RR�
R�
R�RR�
R�
t
get_serverR�
tlistenerR�RaRZR�
RdR�
R.RcR�
(RRCR&tsrvrtaddrRfR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_rapid_restart>s$


!

	


$












(R"R#R�R�
R�
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
4sR�
t_TestConnectioncBs+
eZ
dZed��
Zd�Zd�Zd�Zd�Zed��
Z	ee
d�
�
Zej
ed	�d
��
Zej
ed	�ejejdkd�ejed
k
d�ej
eed�d�d��
�
�
�
Zed��
Zej
ed	�ejejdkd�d��
�
ZRS(R%R'cCs8x't|
j
t�D]}|
j|�

qW|
j�
dS(
N(R�t
recv_bytestSENTINELt
send_bytesR�(RQtconntmsg((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_echo`s

c
Cs@|j�\}
}|j
d
|jd|f
�}t|_|j�
dddg}td�
}|d}tjdt	d�
�}|j
d	kr�|jt|
j
��
t�
n|j|
j|�
d�
|j|
j�|�
|j|
j|�
d�
|j|
j�|�
|j
d	kr�tjdd
g
d�}t|�
d
g
dt|�
}	|j|
j|�
d�
|j|
j|�
t|�
|j�
|jt|�
|	�
tjdd
g
d�}d
g
dt|�
d
g
dt|�
}	|j|
j|�
d�
|j|
j|d|j�t|�
|j�
|jt|�
|	�
ttdd
�
�
}|j|
j|�
d�
y|
j|�
}
Wn,tjk
r�
}
|j|j|f
�
q�X|jd|
�

nt|
j�
}|j|�t�
|j|j d
�
|j|t!�
t�
|j|j t!�
|
jd�

t"j#d�

|j|t!�
t�
|j|j d
�
|j|
j�d�
td�
d}
|
j|
�

|j|
j�|
�
|
jt$�

|j%�
|j
d	kr2|j|
j&t�
|j|
j't�
|j(t)|
j�
|j(t)|
j�
n|j*�
dS(NRVRi
g@shello worldi
RyiR%iit
 i(sexpected BufferTooShort, got %sg�������?t
Xiiiii
(+R{RZR�
R[RFRaRR*
R/
RuR?R.R_tfilenoRnRtR~R�
R�
R`RItrecv_bytes_intotitemsizet	bytearrayRltBufferTooShortRR�RR|R\R,RR�RRhR�
R�treadabletwritableR�tEOFErrorRd(RR�
R�RfR,
R�
tlongmsgR0
tbufferR�R0ReR|treally_big_msg((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_connectionfsn

	










!




,
























c
Cs�|jd
t
�
\}
}|j|jd�
d�
|j|
j�d�
|jdkr�|j|
jt�
|j|
j	t
�
|j|jt
�
|j|j	t�
|j
t|
jd�
|j
t|j�
|j
t|j�
ndS(NRzi
R%i(
R{R\R.RtRR~R?R�
R[R�
R�tIOErrorR|(Rtreadertwriter((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_duplex_false�s










c
Cs�|j�\}
}|j
d
|jd|f
�}t|_|j�
|j�
td�
}|
j|�

|j	|
j
�|�
|
jt�

|
j�
|j�
dS(NRVRRS(
R{RZR�
R[RFRaR�R*
R�
R.R�
R�
Rd(RR�
R�RfR�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_spawn_close�s
	










c
Cs�
|jd
kr+|j
dj|j�
�

ntd�
}
|j�\}}|j|
�

|j|j�|
�
|j|
d�
|j|j�|
d�
|j|
dd�
|j|j�|
dd!�
|j|
d�
|j|j�td�
�
|j|
dd	�
|j|j�td�
�
|jt	|j|
d
�
|jt	|j|
dd�
|jt	|j|
dd�
|jt	|j|
d
�
|jt	|j|
dd
�
dS(NR%stest not appropriate for {}tabcdefghijklmnopqrstuvwxyziiiiR�
iiii
i����ii(
R?R@RAR*
R{R�
R.R�
R�R(RR�
R*R+((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_sendbytes�s&








cCsHytj
|
�

Wn,tk
r?
}
|jtjkr9tS�nXtSdS(
N(RtfstattOSErrorterrnotEBADFR\R[(RQtfdRe((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_is_fd_assigned�s




cCs�|rKxBtd
d�D].}|j
|�
stj|
j�|�
qqWntj|
�
}trxtj|tj	�}ntj
||�
tj|�

dS(Nii
(RuR�
Rtdup2R�
Rtrecv_handletmsvcrttopen_osfhandletO_WRONLYR�R�(RQR�
tdatatcreate_dummy_fdsRyR�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_writefd�s


 




s$test needs multiprocessing.reductionc
Cs
|jd
kr|j
d�

n|jdt�
\}
}|jd|jd|df�}t|_|j�
|jt	j
t	j�
tt	jd��A}|j
�}tr�tj|�
}ntj|
||j�
WdQX|j�
tt	jd��}|j|j�d�
WdQXdS(	NR%sonly makes sense with processesRzRVRR�
twbtrb(R?R@R{R[RZR�
RFRaR�RR�R�R�R�
R�
t
get_osfhandleRtsend_handleRPRdR.R�(RR�
R�RfR�R�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_fd_transfers

!
	











Rs*test semantics don't make sense on Windowsi
s)largest assignable fd number is too smallR�
stest needs os.dup2()c
	Cs_
|jd
kr|j
d�

n|jdt�
\}
}|jd|jd|dtf�}t|_|j�
|jt	j
t	j�
tt	jd���}|j
�}x7tdt�D]}|j|�
s�Pq�q�W|jd	�

tj||�
ztj|
||j�
Wdtj|�

XWdQX|j�
tt	jd
��}|j|j�d�
WdQXdS(NR%sonly makes sense with processesRzRVRR�
R�
i
s2could not find an unassigned large file descriptorR�
(R?R@R{R[RZR�
RFRaR�RR�R�R�R�
RutMAXFDR�
R�RR�
RR�
RPR�RdR.R�(RR�
R�RfR�R�
tnewfd((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_large_fd_transfers(	

$
	















cCstj
|
j�d
�
dS(Ns
(RR�R�
(RR�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_send_data_without_fd?ssdoesn't make sense on Windowsc
Cs�|jd
kr|j
d�

n|jdt�
\}
}|jd|jd|f
�}t|_|j�
|jt	t
j|
�
|j�
dS(NR%sonly makes sense with processesRzRVR(
R?R@R{R[RZRRFRaR�R�RR�
Rd(RR�
R�Rf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_missing_fd_transferCs


	



(R%R'(R"R#R3R�R�
R�
R�
R�
R�
R�
R\R�
Rt
skipUnlesst
HAS_REDUCTIONR�
R<
R�tplatformRR�RRRR(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
\s(	L	
		 







t_TestListenerClientcBs/eZ
dZed��
Zd�Zd�ZRS(R%R'cCs-|jj
|
�
}|jd
�

|j�
dS(NRS(t
connectiontClientRtR�(RQR�
R�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRRVs


c
Cs�x�|jj
D]�}
|jjd
|
�
}|jd|jd|jf
�}t|_|j�
|j	�}|j
|j�d�
|j�
|j
�
q
WdS(NtfamilyRVRRS(R	tfamiliestListenerRZRRR�
R[RFRatacceptR.R~RdR�(RRt
lRfR�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_listener_client\s


!
	






c
Cs�|jj
�}
|jd
|jd|
jf
�}t|_|j�
tj	d�

|
j
�}|j|j�d�
|j
�
|j�
|
j
�
dS(NRVRi
RS(R	R
RZRRR�
R[RFRaRRhRR.R~R�Rd(RRRfR�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_issue14725gs

!
	









(R%R'(R"R#R3R�RRRR(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRRs	t	_TestHeapc
Bs eZ
dZd
�Zd�ZRS(R%c
Cs
d
}
d}g}xzt|
�
D]l}t
tjdd�d�
}tjj|�
}|j|�

t|�
|krtj	|�
}||=qqWtjjj
}g}d}	|jj�
|j
|jj�

x]|jj�D]L}
xC|
D];\}}}
|j|jj|�
||
|
|df�

q�Wq�WxT|jD]I\}}}
|j|jj|�
||
|
|df�

|	|
|7}	q4
W|j�
x{tt|�
d�
D]c}||d \}}}
||dd \}}}|j||kr�
|dkp
|
|k�

q�
WdS(	Ni�i2ii
i�tfreetoccupiedi(R�RntrandomtlognormvariateRltheapt
BufferWrapperR}RIt	randranget_heapt_lockR�R�R�t_len_to_seqR
t_arenastindext_allocated_blockstsortRuRD(Rt
iterationst	maxblockstblocksRyR2
R+RR�
Rt
LtarenaRaR�tnarenatnstarttnstop((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt	test_heap�s:


























c
Cs�tj
�s)tj�
|jtj�

ntj�}
|jtj|
�

tjd
�

xJtd�
D]<}tj	j
d�
}tj	j
d�
}||_||_qbWdS(Ni
i�i
(R�
t	isenabledtenableR�tdisablet
get_thresholdt
set_thresholdRuRlRRtbuddy(Rt
thresholdsRyR*R+((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_free_from_gc�s








	
(
R%(R"R#R3R)R1(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�s	't_FoocBs eZ
defd
efgZRS(R
R

(R"R#RRt_fields_(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR2s	
t_TestSharedCTypescBsDeZ
dZd
�Zed��
Zed�
Zd�Zd�Z	RS(R%c

Csts|j
d
�

ndS(Ns%requires multiprocessing.sharedctypes(R
R@(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR
"s

cCs||
jd
9_|jd
9_|j
d
9_
|jd
9_|jd
9_x*tt|�
�
D]}||cd
9<q^WdS(Ni(R/R
R

RuRI(RQR
R

R�
R0
tstringRy((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_double&s





c		Csn
td
dd|
�
}tt
ddd|
�
}ttddd|
�
}|jdtd	�
d|
�
}|jd
dd|
�
}td�
|_|jd
|jd|||||f�}t	|_
|j�
|j�
|j
|jd�
|j|jdd�
|j
|jd�
|j|jd�
x,td	�
D]}|j|||d�
q/
W|j
|jtd�
�
dS(NRyiR�g�?g@iiR

i
R=iRSRVRig@ig@t
hellohello(RRR2R.
RuR*
R/RZR6R[RFRaRdR.R)R
R

(	RR�R
R

R�
R0
R5RfRy((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_sharedctypes0s"





*
	









c

Cs|jd
t
�

dS(NR�(R8R[(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_synchronizeEs
c
CsWtd
d�}
t
|
�
}d|
_d|
_|j|jd
�
|j|jd�
dS(Nig@i(R2RR
R

R.R)(RR�
R�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt	test_copyHs


	
	

(
R%(
R"R#R3R
R�R6R\R8R9R:(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR4s	
	t
_TestFinalizecBsAeZ
dZd
�Zd�Zed��
Zd�Zd�ZRS(R%c

Cs#tj
j�|_tj
j�
dS(
N(Rt_finalizer_registryRtregistry_backupR
(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR
Xs

c

Cs'|jt
j�

t
jj|j�

dS(
N(R
RR<tupdateR=(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttearDown\s

cCs�
d
tf
d��Y}|�}t
j||
jdd�

~|�}t
j||
jdd�
}|�
|�
~|�}t
j||
jdd�

|�}t
j||
jdddd	�
|�}t
j||
jdddd�
|�}	t
j|	|
jdddd�
|�}
t
j|
|
jdddd�
t
jd|
jdddd�
t
jd|
jdddd�
t
j�
|
j�
tjd�

dS(NR�
c
BseZ
RS((R"R#(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
bs
RR*R+R=td10texitpriorityi
td01itd02td03Rei����tSTOPi����(
R*(
R+(
R=(
R@(
RB(
RC(
RD(
Re(
RE(	R�RtFinalizeRtRt_exit_functionR�Rt_exit(RQR�
R�
R*R+tclose_bR=R@RBRCRD((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_test_finalize`s0	

	



	
	
	

	

	




c
	Cs�|j�\}
}|j
d
|jd|f
�}t|_|j�
|j�
gt|
jd�D]}|^q`}|j	|dddddd	d
g�
dS(NRVRRER*R+R@RDRCRBRe(
R{RZRJR[RFRaRdR�R~R.(RR�
R�RfR�R�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_finalize�s

	



%
c
s 
d
��
dtf
�
f
d��Y�t
�g���fd�}
���fd�}tj�}tj�}z�tjd�

tjddd�
tj	d|
�
tj	d|�
g}t
j|�
�
tj
d	�

t�WdQX�r��d
�
nWdtj|�

tj|�
tj�
XdS(Nc
SsdS(
N((((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytcb�s
R�
cseZ
�f
d�ZRS(
c

s/||_t
j|�d
tjdd��

dS(NRAi
id(R�RRFRtrandint(
R(
RL(s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�s
	(R"R#R((
RL(s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�s
c
sYxR�
sTtj
tj�d
�

ytj�
Wqtk
rP
}
�j|�

qXqWdS(Ng�������?(RRhRRt_run_finalizersR�
R}(
Re(texctfinish(s5/usr/local/lib/python2.7/test/test_multiprocessing.pytrun_finalizers�s
	



csqi}xd�sly-�f
d
�td�
D�
|t
jd�
<Wq	tk
rh
}

�
j|
�

|j�
q	Xq	WdS(Nc
sh|]}
���qS(((RD
Ry(
R�
(s5/usr/local/lib/python2.7/test/test_multiprocessing.pys	<setcomp>�s	i
i(RuRtgetrandbitsR�
R}R
(R

Re(R�
RORP(s5/usr/local/lib/python2.7/test/test_multiprocessing.pytmake_finalizers�s

	
-



i
iRVg@i(R�R\R�tgetcheckintervalR�
R-tsetcheckintervalR.R�R�Rt
start_threadsRRhR[R�
(RRQRStold_intervalt
old_thresholdR'((R�
RLRORPs5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_thread_safety�s*	


















(
R%(	R"R#R3R
R?R�RJRKRY(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR;Ts		&	t_TestImportStarc
BseZ
dZd
�ZRS(R%c
Cs�d
dddddddg}
tr4|
j
d	�

ntdk	rP|
j
d
�

nxe|
D]]}t|�

tj|}x=t|dd
�D])}|jt	||�d||f�
q�WqWWdS(NRlsmultiprocessing.connectionsmultiprocessing.heapsmultiprocessing.managerssmultiprocessing.poolsmultiprocessing.processsmultiprocessing.synchronizesmultiprocessing.utilsmultiprocessing.reductionsmultiprocessing.sharedctypest__all__s%r does not have attribute %r((
RR}RRR�R�tmodulestgetattrRDR�(RR\ROtmodtattr((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_import�s











(
R%(R"R#R3R`(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRZ�st_TestLoggingcBs/eZ
dZd
�Zed��
Zd�ZRS(R%c
CsZtj
�}
|
jtj�

|j|
dk	�

|
jd
�

|
jd�

|
jt	�

dS(Nsthis will not be printeds
nor will this(
Rlt
get_loggertsetLevelRt
SUBWARNINGRDRtdebugtinfot	LOG_LEVEL(Rtlogger((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_enable_logging�s







cCs#tj
�}|
j|j��

dS(
N(RlRbRttgetEffectiveLevel(RQR�
Rh((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_test_level�s
c
	Cs
d
}
d}tj
�}tj�}|j}tjdt�
\}}|j|
�

|jd|j	d|f
�}t
|_|j�
|j
|
|j��
|jtj�

|j|�

|jd|j	d|f
�}t
|_|j�
|j
||j��
|j|�

|jdt�

dS(Ni i%RzRVRtlevel(RlRbtloggingt	getLoggerRlR{R\RcRZRkR[RFRaR.R~tNOTSETRg(	RtLEVEL1tLEVEL2Rhtroot_loggert
root_levelR�
R�
Rf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_level�s&



	


	






	




(
R%(R"R#R3RiR�RkRt(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRa�s	t_TestPollEintrcBsAeZ
dZed
��
Zejeed�d�d��
Z	RS(R%cCs$tj
d
�

tj|
tj�
dS(Ng�?(RRhRtkilltsignaltSIGUSR1(RQRP((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_killer2	s

Rxsrequires SIGUSR1c
s�tg
��f
d
�}
t
j�}tjtj|
�}z�|jd|jd|f
�}|j�
|jdtj	dd�}|j�
|j
�
|j�d�

|j|j
d�
|j
�
Wdtjtj|�
XdS(Nc
st�d
<dS(Ni(
R[(
R(
t
got_signal(s5/usr/local/lib/python2.7/test/test_multiprocessing.pytrecord:	s
RVRi
i(
i
(R\RRKRwRxRZRyRaRRhRdRDR.RL(RR{RPt
oldhandlertkillerRf((
Rzs5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_poll_eintr7	s	













(
R%(
R"R#R3R�RyRRR�RwR~(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRu.	stTestInvalidHandlecBs#eZ
ejed�d
��
ZRS(sskipped on Windowsc
Cs<tj
d
�
}
|jt|
j�
|jttj
d�
dS(Ni�M�i����(Rt
ConnectionR�R�
R|(RR�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_invalid_handlesP	s

(R"R#RR<
tWIN32R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyRN	scCs[i}xN|
D]F}t||�}t
|�
t
t�
krIt|�
}n|||<q
W|S(
N(R]R_tget_attributeststaticmethod(tSourcetnamesR

ROR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�Z	s







c	Cs�i}t�}|
j
�}x�|j�D]�}|jd
�
r(||}|
|jkr�d||d}d|tj|fd��Y}|||<||_|j|_q�q(q(W|S(Nt_TesttWithi
tTempc
BseZ
RS((R"R#(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�m	s
(	tglobalst
capitalizeRG
t
startswithR3RtTestCaseR"R#(	tMixinR_R�tglobtTypeROtbasetnewnameR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytcreate_test_casesc	s

	








	

tProcessesMixincBs0eZ
dZejZe�jeed��

RS(R%RXR�R�R�R�R�RYRR.
R
R-
RBR^R{R	R�Rx
(RXR�R�R�R�R�RYRR.
R
R-
RBR^R{R	R�Rx
(R"R#R?RlRZtlocalsR>R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�x	s

	




R_R%tManagerMixincBsEeZ
dZejZejejj�
Z	e
�jee	d��

RS(R&RXR�R�R�R�R�RYRR.
R`RE
RP
R�Rx
(RXR�R�R�R�R�RYRR.
R`RE
RP
R�Rx
(
R"R#R?RlRZR�RX
tmanagerstSyncManagerR&R�R>R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��	s

	




R&tThreadsMixincBs6eZ
dZejjZe�jeejd��

RS(R'RXR�R�R�R�R�RYRR.
RBR^R{R	RE
R`RP
R�Rx
(RXR�R�R�R�R�RYRR.
RBR^R{R	RE
R`RP
R�Rx
(	R"R#R?RltdummyRZR�R>R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��	s






R't	OtherTestc
BseZ
d�Zd
�ZRS(c
Cs<d
tf
d��Y}
|j
tjtjj|
�d�
dS(Nt_FakeConnectionc
BseZ
d�Zd
�ZRS(c
Ssd
S(Nssomething bogus((RR2
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�	s
c
SsdS(
N((RR�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�	s
(R"R#R�
R�
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��	s
	tabc(R�R�RltAuthenticationErrorR	tdeliver_challenge(RR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt#test_deliver_challenge_auth_failure�	s

	
c
Cs<d
tf
d��Y}
|j
tjtjj|
�d�
dS(NR�c
Bs#eZ
d�Zd
�Zd�ZRS(c

Ss
d
|_dS(Ni(
tcount(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�	s
cSs?|jd
7_|jd
kr(t
jjS|jdkr;dSdS(Ni
issomething bogusR�
(R�RlR	t	CHALLENGE(RR2
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�	s






c
SsdS(
N((RR�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�	s
(R"R#RR�
R�
(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��	s
		R�(R�R�RlR�R	tanswer_challenge(RR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt"test_answer_challenge_auth_failure�	s

	
(R"R#R�R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��	s	
c

Cs|jd
7_dS(Ni
(
R�(
tns((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytinitializer�	s
tTestInitializersc
Bs,eZ
d�Zd
�Zd�Zd�ZRS(c

Cs1tj
�|_|jj�|_d
|j_dS(Ni(RltManagertmgrRP
R�R�(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR
�	s


c


Cs|jj
�
dS(
N(R�R�
(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR?�	s
c
Cs_tj
j�}
|jt|
jd
�
|
jt|jf
�
|j|jj	d
�
|
j
�
dS(Ni
(RlR�R�R�t	TypeErrorRaR�R�R.R�R�
(Rt
m((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_manager_initializer�	s





c
Csb|jt
tjd
d�

tjdt|jf
�}
|
j�
|
j�
|j|jj	d�
dS(NR�i
(
R�R�RlRx
R�R�R�RdR.R�(RRf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_pool_initializer�	s







(R"R#R
R?R�R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��	s
			c
Cs1y|jd
t
�
}
Wntjk
r,


n
XdS(Ntblock(RcR\RXR�(R<titem((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_this_sub_process�	s



c
CsHtj
�}
tjd
td|
f
�}t|_|j�
|j�
dS(NRVR(RlRXRZR�R[RFRaRd(R<R�tsubProc((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
_test_process�	s



	


c

Cs||S(
N((
R
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_afunc�	s
c	Cs=tj
d
d�
}|jtdddddddg�}
dS(	NR%ii
iiiii(RlRx
Rd
R�(R_
R
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytpool_in_process�	s

t
_file_likecBs2eZ
d�Zed
��
Zd�Zd�ZRS(cCs|
|_d|_dS(
N(t	_delegateRt_pid(Rtdelegate((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�	s
	
c
Cs7tj
�}
|
|jkr0|
|_g|_n|jS(
N(RRKR�t_cache(RRP((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytcache�	s

	

cCs|jj
|
�

dS(
N(R�R}(RR�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
s
c

Cs)|jj
d
j|j�
�

g|_dS(NR�
(R�R�RdR�R�(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytflush
s

(R"R#RtpropertyR�R�R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��	s
			tTestStdinBadfiledescriptorc
Bs#eZ
d�Zd
�Zd�ZRS(c
Cs?tj
�}
tjd
td|
f
�}|j�
|j�
dS(NRVR(RlRXRZR�RaRd(RR�R�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_queue_in_process
s




c
Cs*tj
d
t�
}
|
j�
|
j�
dS(NRV(RlRZR�RaRd(RRf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_pool_in_process
s



c
sct�}
t
|
�
��jd
�

tjd�f
d��
}�j�
|
j�d
ks_t�
dS(NR�
RVc
s
�j�S(
N(
R�((
tflike(s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�

R�
(R
R�R�RlRZR�tgetvalueR:(RtsioR�((
R�s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_flushing
s
	






(R"R#R�R�R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�

s		tTestTimeoutscBs eZ
ed��
Zd
�ZRS(cCsQtj
d
�

|
jd�

|
j�
tjj|�
}|jd�

|j�
dS(Ni
i{i�
(RRhRtR�RlR	R
(RQtchildR�
R�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
_test_timeout$
s








c
Cs�tj
�}
z�tjd
�

tjdt�
\}}tjjdd�
}tjd|j	d||j
f�}|j�
|j�
|j
|j�d�
|j�
|j�}|j
|j�d�
|j�
|j�
|jd	�

Wdtj|
�

XdS(
Ng�������?RzRtAF_INETRVRi{i�
i
(tsockettgetdefaulttimeouttsetdefaulttimeoutRlR{R[R	R
RZR�R�
RaR�R.R~RRd(Rtold_timeouttparentR�RRfR�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�-
s"





















(R"R#R�R�R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�#
s
	tTestNoForkBombc
BseZ
d�ZRS(
c
Cs�tj
jtj
jt�
d
�}
tretjj|
�
\}}}|j	|d�
|j
d|�
nAtjj|
�
\}}}|j	|j�d�
|j	|d�
dS(Nsmp_fork_bomb.pyR�
R�t123(
RtpathRdtdirnamet__file__R�R�t
script_helpertassert_python_failureR.Rbtassert_python_okR�(RROtrctoutterr((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_noforkbombF
s
!





(R"R#R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�E
s
t	TestFlagscBs8eZ
ed��
Zed
��
Zejd��
ZRS(cCs|
jt
tj�
�

dS(
N(RtR�
R�tflags(RQR�
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytrun_in_grandchildV
sc
Cs�d
dl}
t
jdt�
\}}t
jd|jd|f
�}|j�
|j�}|j�
|j	�
|j	�
t
tj�
|f}|
j
|�
GHdS(Ni����RzRVR(tjsonRlR{R\RZR�RaR~RdR�R�
R�R�tdumps(RQR�R�R�Rftgrandchild_flagsR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytrun_in_childZ
s












c
Csxd
dl}
d
dl
}dd}|jtjdddd|g�
}|
j|jd�
�
\}}|j||�
dS(	Ni����s1from test.test_multiprocessing import TestFlags; sTestFlags.run_in_child()s-Es-Bs-Os-ctascii(R�t
subprocesstcheck_outputR�t
executabletloadstdecodeR.(RR�R�tprogR�
tchild_flagsR�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt
test_flagsg
s




(R"R#R�R�R�Rtrequires_unicodeR�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�U
s

tTestForkAwareThreadLockcBs eZ
ed��
Zd
�ZRS(cCsl|
d
krHtj
d|jd|
d
|f�}|j�
|j�
n|jttj�
�

|j	�
dS(Ni
RVR(
RlRZR�RaRdRtRIRt_afterfork_registryR�(RQRR
R�
Rf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�{
s
%




c
Cs�tj
t�
\}
}tj�}ttj�
}tjd
|jdd|f�}|j	�
|
j
�}|j�
|j||�
dS(NRVRi(
RlR{R\RtForkAwareThreadLockRIR�RZR�RaR~RdtassertLessEqual(RR�R�Rtold_sizeRftnew_size((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��
s



!





(R"R#R�R�R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�v
s
tTestIgnoreEINTRcBs�eZ
eejej�Zed��
Ze	j
eed
�d�d��
Z
ed��
Ze	j
eed
�d�d��
ZRS(cCsZd
�}tjtj
|�
|
jd�

|
j�}|
j|�

|
jd|j�

dS(Nc
SsdS(
N((tsignumtframe((s5/usr/local/lib/python2.7/test/test_multiprocessing.pythandler�
s
treadyR
(RwRxRtR~R�
t
CONN_MAX_SIZE(RQR�
R�R
((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_test_ignore�
s	





Rxsrequires SIGUSR1c
Cs#
tj
�\}
}z�tjd
|jd|f
�}t|_|j�
|j�
|j|
j	�d�
t
jd�

tj
|jtj�
t
jd�

|
jd�

|j|
j	�d�
t
jd�

tj
|jtj�
|j|
j�d|j�
t
jd�

|j�
Wd|
j�
XdS(NRVRR�g�������?i�R
(RlR{RZR�R[RFRaR�R.R~RRhRRvRPRwRxRtR�
R�Rd(RR�
R�Rf((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_ignore�
s&



	



















cCsXd
�}tjtj
|�
tjj�}|
j|j�

|j�}|jd�

dS(Nc
SsdS(
N((R�R�((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��
s
twelcome(RwRxRlR	R
RtR�
R(RQR�
R�RR*((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt_test_ignore_listener�
s	



c
Cs�tj
�\}
}z�tjd
|jd|f
�}t|_|j�
|j�
|
j�}t	j
d�

tj|j
tj�
t	j
d�

tjj|�
}|j|j�d�
|j�
Wd|
j�
XdS(NRVRg�������?R�(RlR{RZR�R[RFRaR�R~RRhRRvRPRwRxR	R
R.Rd(RR�
R�RfR�
tclient((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyttest_ignore_listener�
s



	












(R"R#tmaxRt
PIPE_MAX_SIZEt
SOCK_MAX_SIZER�R�R�RRR�RwR�R�R�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR��
s

$
c
s�
tj
jd
�
rHytj�}
WqHtk
rD


tjd�
�
qHXnt�
|dkrnddl
m}
ntj
�
tj�jt�

tjd�
t_tjjd�
t_tjj�
tjj�
tjjd�
t_ttj�dd��

ttj�dd��

ttj�dd	��

t}tj j!�tj"�f
d
�|D�
�
}t#j$dt%fdt%fd
t&�
�
||�

WdQXtjj'�
tjj'�
tjj'�
tjj(�
t`t`t`dS(Ntlinuxs1OSError raises on RLock creation, see issue 3111!i����(
trun_unittestitkeyc


Ss|jS(
N(
R"(
ttc((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�
R�
c


Ss|jS(
N(
R"(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�
R�
c


Ss|jS(
N(
R"(
R((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyR�
�
R�
c
3s|]}
�|
�
V
qdS(
N((RD
R(
tloadTestsFromTestCase(s5/usr/local/lib/python2.7/test/test_multiprocessing.pys	<genexpr>ss%.+__(get|set)slice__ has been removedssys.exc_clear\(\) not supportedtquiet()R�RR�RlR�R�
RRRRttest.supportRRtget_temp_dirRbRcRgRx
R�R_
R�R�R�R&RRaRF
ttestcases_processesR
ttestcases_threadsttestcases_managerttestcases_othertdefaultTestLoaderRt	TestSuiteRtcheck_py3k_warningstDeprecationWarningR[RjR�
(R�R�t	testcasestsuite((
Rs5/usr/local/lib/python2.7/test/test_multiprocessing.pyt	test_main�
s:













J


	










cCstt
jd
d�
j�

dS(Nt	verbosityi(RRtTextTestRunnerR�(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pytmains
t__main__(g=
ףp=�?gffffff�?gffffff�?(g�������?g�������?g�������?(R�R�
(�RRXRR�RR�
RwR/
R�RRmR�
R�ttest.script_helperR�RR
t
import_moduleRR�tmultiprocessing.dummyRltmultiprocessing.connectiontmultiprocessing.managerstmultiprocessing.heapR�
RRR[RtImportErrorR\tmultiprocessing.sharedctypesRRR
R�
RR�R*
RdRgRqR(R�R�R�R]t
HAVE_GETVALUERR�RRtctypesR
RRR�RRR$R5R8R>RZR�R�R�R�R�R�R�R�R
R	
R+
R=
RT
RU
RV
RRZ
R]
R^
R�
R�
R�
R�
R�
R�
R�
R�
R�
R�
R�
tregisterR�
R�
R�
R�
R�
R�
R�
R�
R�
R�
RRR2R4R;RZRaRuR�RR�R�R�RR�R>R�R	R�RR�R�R�R�R�R�R�R�R�R�R�R�R�R�R
RRR"(((s5/usr/local/lib/python2.7/test/test_multiprocessing.pyt<module>s$








































	








 



		�		�6�-EZS	
	�	2		

$
	
4&��E6v!C 			





!					"!G	
	
0