✘✘ GRAYBYTE WORDPRESS FILE MANAGER ✘✘

�
zfc	@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((s1/usr/lib64/python2.7/test/test_multiprocessing.pytcheck_enough_semaphorescs





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

(t__name__t
__module__RR!(((s1/usr/lib64/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((s1/usr/lib64/python2.7/test/test_multiprocessing.pytassertTimingAlmostEqual�s

cGs8y||�}Wntk
r#


nX|j
|
|�SdS(
N(tNotImplementedErrortassertEqual(RtvalueRRtres((s1/usr/lib64/python2.7/test/test_multiprocessing.pytassertReturnsIfImplemented�s





c
Gstd
�
�
dS(Ns#shouldn't try to pickle a test case(
R-(RR((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt
__reduce__�s
(R%R&R'(R"R#t
ALLOWED_TYPESR,R1R2t
__reduce_ex__(((s1/usr/lib64/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((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR5�s












t
DummyCallablec
BseZ
d�ZRS(
cCs|
jd
�

dS(Ni(
tput(Rt
qt
c((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR!�s(R"R#R!(((s1/usr/lib64/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(RtcurrentRA((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_current�s


	




cOsr|j�}|
j
|�

|
j
|�

|
j
|j�

|jd
krn|
j
t|j�
�

|
j
|j�

ndS(NR'(R@R9tnameR=RFRAtpid(tclsR:RRRK((s1/usr/lib64/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@tbyetSomeProcessttargetRtkwargsRMR'i(tQueuetEventtProcessRPtTrueRDR@R=R.RARCtFalsetassertNotIntactive_childrenRBttypetlistRJRtstarttassertIntgetRMRNtjoin(RR:t
eRRURMt
pRK((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_process�s<





	
	

















c

Cstj
d
�

dS(Ni�(Rtsleep(
RO((s1/usr/lib64/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 {}RTg(R=R>R?RXRgRYRDR_R.RCR`R\RJRt	terminateRRbR,RRZR[(RRdRb((s1/usr/lib64/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-RBR]tint(Rtcpus((s1/usr/lib64/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(NRTR(R.R]R\R^RXRRftDELTAR[RYRDR_R`Rb(RRd((s1/usr/lib64/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����(
tforkingiRTR(	RjRqtsendRGtrangeRXt_test_recursionR_Rb(ROtwconntidRqt
iRd((s1/usr/lib64/python2.7/test/test_multiprocessing.pyRt.
s




	


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

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

q>Wgdg
ddgddgdg
ddgddgg}|j	||�
dS(Ntduplexii
(
tPipeRZRtRRfRotpolltappendtrecvR.(RtrconnRutresulttexpected((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_recursion:
s







	
	

	
cCs#t|d
�t
_t
j|
�

dS(Nt
w(topentsyststderrtexit(ROtreasonttestfn((s1/usr/lib64/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 thisRTRit
ri(signore thisi
(R=R>R?RtTESTFNt
addCleanuptunlinkRXR�RYRDR_RbR.RJR�treadtrstriptstrRZR�R�(RR�R�tcodeRdt
f((s1/usr/lib64/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(NRTRi(R8tweakreftrefRVRXR_RbtassertIsRR.Ra(RR;twrR:Rd((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_lose_target_refl
s
	









(R%R'(R"R#R3RLtclassmethodRPReRgRiRnRpRtR�R�R�R�(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR<�s	
	'			
		t_UpperCaserc
Bs,eZ
d�Zd
�Zd�Zd�ZRS(c

Cs,tj
j|�

tj�\|_|_dS(
N(RjRXRRyt
child_conntparent_conn(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR~
s

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

q#W|jj
�
dS(
N(R�tclosetiterR�R|RRrtupper(Rt
s((s1/usr/lib64/python2.7/test/test_multiprocessing.pytrun�
s




cCs|jj
|
�

|jj�S(
N(R�RrR|(RR�((s1/usr/lib64/python2.7/test/test_multiprocessing.pytsubmit�
s
c

Cs.|jj
d�

|jj�
|jj�
dS(
N(R�RrRR�R�(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pytstop�
s



(R"R#RR�R�R�(((s1/usr/lib64/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(NRQtHELLOtworldtWORLD(R�RYRDR_R.R�R�Rb(Rt
uppercaser((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_subclassing�
s
	
	






(
R%(R"R#R3R�(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR��
sc

Cs-t|d
�r|j
�S|j�dkSdS(Ntemptyi(thasattrR�tqsize(
R:((s1/usr/lib64/python2.7/test/test_multiprocessing.pytqueue_empty�
s


cCs-t|d
�r|j
�S|j�|
kSdS(Ntfull(R�R�R�(R:tmaxsize((s1/usr/lib64/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(twaitRsRatset(ROtqueuetchild_can_starttparent_can_continueRw((s1/usr/lib64/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�RTRi
iiiiiittimeout(RVRWRXR�RYRDR_R.R�R�RZR9Rt
put_nowaitRRfRoRtassertRaisestFullR,RtTIMEOUT1tTIMEOUT2tTIMEOUT3R�R�Rb(RtMAXSIZER�R�R�tprocR9R�((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_put�
sN



	
	
	






















cCsL|j�
|
j
d
�

|
j
d�

|
j
d�

|
j
d�

|j�
dS(Niiii(R�R9R�(ROR�R�R�((s1/usr/lib64/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(
NRTRiiR�i
iii(RVRWRXR�RYRDR_R.R�R�R�RRfRoRZRaRt
get_nowaitRR�tEmptyR,RR�R�R�Rb(RR�R�R�R�RaR�((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_get�
sB


	
	
	
















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

qWdS(Ni
i(RsR9(ROR�Rw((s1/usr/lib64/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
RTRi(RVRsR9RRfRoRXR�RYRDR_R.RaR�R�RZRb(RR�RwRd((s1/usr/lib64/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(RVR.R�R-R>R9Ra(RR:((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt
test_qsizeUs

















cCs8x1t|
j
d�D]}tjt�

|
j�
qWdS(
N(R�RaRRRfRot	task_done(ROR:tobj((s1/usr/lib64/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()' methodiRTRi
(ii(t
JoinableQueueR�tversion_infoR�R>txrangeRXR�RYRDR_R9RbR(RR�RwtworkersRd((s1/usr/lib64/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__RVR�tfail(Rtmodule_nameR�((s1/usr/lib64/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((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR2�s
(R"R#R2(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR��s
R�g�?(R=R>R?tobjectttestRtcaptured_stderrRVR9RYRBRa(RR�R:((s1/usr/lib64/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�(((s1/usr/lib64/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.tacquireRYRZtreleaseRR�Rt	threadingtThreadError(Rtlock((s1/usr/lib64/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�RYR�RR�tAssertionErrortRuntimeError(RR�((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt
test_rlock�s







c

Cs|j��
WdQXdS(
N(
R�(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_lock_context�s


(R"R#R�R�R�(((s1/usr/lib64/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�RYRZR�R(Rtsem((s1/usr/lib64/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�((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_semaphore�s






c
Cs |jd
�
}
|j
|
�

dS(Ni(tBoundedSemaphoreR�(RR�((s1/usr/lib64/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>R?R�RR�R.RZR,RRR�RYR�R�(RR�R�((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_timeout�s







(R"R#R�R�R�R�(((s1/usr/lib64/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�(ROtcondtsleepingtwokenR�((s1/usr/lib64/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((s1/usr/lib64/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(NiRTRi
i(t	ConditionR�RXR�RYRDR_R�tThreadR�RRfRoR1R5tnotifyR�R�Rb(RR�R�R�Rd((s1/usr/lib64/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(NiiRTRii
(R�R�RsRXR�R�RYRDR_R�R�R�R�R1R5R�RRfRot
notify_allR�R-(RR�R�R�RwRdR ((s1/usr/lib64/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((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�ys








N(	R"R#R�RR�R�R�R

R�(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR��s
		+	At
_TestEventcBs eZ
ed��
Zd
�ZRS(cCstj
t�

|
j�
dS(
N(RRfR�R�(ROtevent((s1/usr/lib64/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(NgRTR(RWRR�R.tis_setRZR,RR�R�RYtclearRXR
RDR_(RR
R�Rd((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt
test_event�s$











	


(R"R#R�R
R
(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR
�st
_TestValuecBskeZ
dZdddd
ed�
ed�
fgZd
�Zed��
Zed�
Z	d�Z
d�ZRS(R%Rwi�i�^t
dg
@g�t
hi���i�R;t
xt
yc

Csts|j
d
�

ndS(Ns%requires multiprocessing.sharedctypes(tHAS_SHAREDCTYPESR>(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pytsetUp�s

cCs4x-t|
|j
�D]\}}|d
|_qWdS(Ni(tziptcodes_valuesR/(ROtvaluestsvtcv((s1/usr/lib64/python2.7/test/test_multiprocessing.pyRP�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
RTRi(R
tRawValueRR
R.R/RXRPRYRDR_Rb(	RtrawR�R/t
_R
R
R
R�((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt
test_value�s


1
.

	




c

Cs|jd
t
�

dS(NR
(R
RY(
R((s1/usr/lib64/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(NRwiR�tget_locktget_objtnavalue(RR
R
RR�R.RZtassertFalseR�R�RR
(
Rtval1tlock1tobj1tval2tlock2tobj2R�tval3tlock3tobj3tarr4tarr5((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_getobj_getlock�s$












(
R%(Rwi�i�^(R	
g
@g�(R

i���i�(R"R#R3tlatinR
R
R�RPRZR
R
R(
(((s1/usr/lib64/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
(RsRG(ROtseqRw((s1/usr/lib64/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?Rwiiii
iiRTR(tRawArraytArrayR.RGR^tarrayR�RXRYRDR_Rb(RR
R+
tarrRd((s1/usr/lib64/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
iRwi(RsR-
R.RGR^(RtsizeR
R/
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_array_from_sizes






c

Cs|jd
t
�

dS(NR
(R0
RY(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt
test_rawarray&sc
CsT|jd
d�}
|j
t|
�
d�
|jd
d�}|j
t|�
d�
dS(NRwl

i
(R-
R.RGR,
(RR/
traw_arr((s1/usr/lib64/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(NRwi
R�R
R
tnotalock(
R-
RsR
R
RR�R.RZR
R�R�RR,
(
Rtarr1R
R
tarr2R!
R"
R�tarr3R$
R%
R&
R'
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_getobj_getlock_obj1s&










	


(
R%N(R"R#R3R�R�RtskipIfRRRZR0
R2
R3
R5
R:
(((s1/usr/lib64/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	RQ(R^RsR.textendR{(RR*R+R	
RcR�((s1/usr/lib64/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^RsR�R.tnext(RR*tit((s1/usr/lib64/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.0Rw((s1/usr/lib64/python2.7/test/test_multiprocessing.pys	<genexpr>�s(	tdictRsRB
R.RtsortedtkeysR
titems(RR	
tindicesRw((s1/usr/lib64/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(
RD
RsRB
R�R.R^R
R�R�R?
(RR	
RH
RwR@
((s1/usr/lib64/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')RMtjob(RK
RL
(t	NamespaceRMRN
t_hiddenR.R�RBR�(Rt
n((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_namespace�s

	
	
	




(
R&(R"R#R3R>
RA
RI
RJ
RR
(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR<
Os		
	
	
gcCstj
|
�

||S(
N(RRf(R
R�((s1/usr/lib64/python2.7/test/test_multiprocessing.pytsqr�s


c


Cs|S(
N((
R
((s1/usr/lib64/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__(
RO((s1/usr/lib64/python2.7/test/test_multiprocessing.pyRW
�s

c

Cst|�
j
d
8_
dS(Ni
(R]RV
(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt__del__�s
(R"R#RV
RW
RX
(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyRU
�s
	tSayWhenErrorc
BseZ
RS((R"R#(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyRY
�sccs;x4t|�
D]&}||
kr.t
d
�
�
n|V
q
WdS(NsSomebody said when(RsRY
(ttotaltwhenRw((s1/usr/lib64/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.RS
(Rtpapply((s1/usr/lib64/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.RS
Rs(Rtpmap((s1/usr/lib64/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((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR2�s
(R"R#R2(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyRf
�s
i
(	R=R>R?R�R�R�R^
Rc
RS
(RRf
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_map_unplicklable�s



c

CsQy)|jj
tgd
d�
jdt�

Wn!tjk
rL


|jd�

n
XdS(NRb
i
R�s2pool.map_async with chunksize stalled on null list(R^
t	map_asyncRS
RaR�RjtTimeoutErrorR�(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_map_chunksize�s

)

c
CsT|jj
td
tf�}
t|
j�
}|j|�d�
|j|jt�
dS(Nii1(	R^
tapply_asyncRS
R�RRaR.R,R(RR0Ra((s1/usr/lib64/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^
Rk
RS
R�RRaR�RjRi
R,R(RR0Ra((s1/usr/lib64/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�Rb
id(
R^
timapRS
RsR.R^Rc
R?
R�t
StopIteration(RR@
Rw((s1/usr/lib64/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>R?R^
Rn
RS
R\
RsR.R?
R�RY
(RR@
Rw((s1/usr/lib64/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�Rb
(R^
timap_unorderedRS
RsR.RE
Rc
(RR@
((s1/usr/lib64/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>R?R^
Rr
RS
R\
Rc
RsR�RY
R?
R`tremove(RR@
texpected_valuesRwR/((s1/usr/lib64/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�RRjtPoolR.RGt_poolR�Rb(RRd((s1/usr/lib64/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�������?Rb
i
g�������?(
Rw
Rh
RRfRsRhRRbRBR(RRdRwR~Rb((s1/usr/lib64/python2.7/test/test_multiprocessing.pyRi.s


.



c
Cs�|jd
�
}
|j
|
jtg�g�
|j
t|
jtg��
g�
|j
t|
jtg��
g�
|j
|
jtg�j�g�
|
j	�
|
j
�
dS(Ni
(Rw
R.Rc
RS
R^Rn
Rr
Rh
RaR�Rb(RRd((s1/usr/lib64/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(
RU
(RC
Rw((s1/usr/lib64/python2.7/test/test_multiprocessing.pys	<genexpr>Gsi
c
ss|]}
tj
|
�
V
qdS(
N(R�R�(RC
t
o((s1/usr/lib64/python2.7/test/test_multiprocessing.pys	<genexpr>Hsc
ss|]}
|
�V
qdS(
N((RC
R�((s1/usr/lib64/python2.7/test/test_multiprocessing.pys	<genexpr>Msi(
R^RsR^
Rc
RT
RRfRoR.R�RRU
RV
(Rtobjstrefs((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_release_task_refsDs




#(R"R#Ra
Re
Rg
Rj
Rl
Rm
Rp
Rq
Rs
Rv
Ry
RiRz
R~
(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR]
�s			
										
	c
Csd
�S(Nc
Ssd
S(Ni*((((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt<lambda>Tt((((s1/usr/lib64/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�
RjRw
RsRk
R�
R�RaR�Rb(RR�
Rdt	iterationR0((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_unpickleable_resultYs





(
R%(R"R#R3R�
(((s1/usr/lib64/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(
RC(RC
R�((s1/usr/lib64/python2.7/test/test_multiprocessing.pys	<genexpr>ysi
(RjRw
R.RGRx
RNRsR{Rk
RS
t	enumerateRat_repopulate_pooltallRRfRoR[RtassertNotEqualRE
R�Rb(
RRdR�torigworkerpidstresultsRwt
jR0t	countdowntfinalworkerpids((s1/usr/lib64/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�?(RjRw
RsR{Rk
RS
R�RbR�
R.Ra(RRdR�
RwR�
R0((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt%test_pool_worker_lifetime_early_close�s


#




(
R%(R"R#R3R�
R�
(((s1/usr/lib64/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
(RjR\tgctcollectR&t_number_of_objectst_debug_infoR.(RtEXPECTED_NUMBERR}
t
debug_info((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_number_of_objects�s









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


Csd
S(Nsf()((
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR��s
c


Cs
t�
dS(
N(
R(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt
g�s
c


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

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


Cs|S(
N((
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt__iter__�s
c

Cs
|jd
�
S(NR?
(
t_callmethod(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR?
�s
c

Cs
|jd
�
S(NR�
(
R�
(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�
�s
(R?
R�
(R"R#t	_exposed_R�
R?
R�
(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�
�s

		t	MyManagerc
BseZ
RS((R"R#(((s1/usr/lib64/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�
R_R�
R�
R�
R�R.R�R�RR�
R�
R�
R�
R^Rstshutdown(	RR&tfootbarR�
RMtfoo_methodstbar_methodsRw((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_mymanager�s&
	



(
(






3(
R&(R"R#R3R�
(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�
�sc
CstS(
N(
t_queue(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt	get_queue�s
tQueueManagerc
BseZ
dZRS(
s$manager class used by server process(R"R#t__doc__(((s1/usr/lib64/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�
(((s1/usr/lib64/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(NtaddressRAt
serializer(R�
t
SERIALIZERtconnectR�
R9ttupleR
(ROR�
RAR&R�((s1/usr/lib64/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�
iRAR�
RTR(RturandomR�
R�RtHOSTR�
R_RXR�
R�
RYRDR�
R�
R�
R.RaR~R�t	ExceptionR9RRfR�
(RRAR&Rdtmanager2R�((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_remotes

!
$
	





(
R&N(R"R#R3RRYR
R~Rthave_unicodet
utuvalueR{R�R�
R�
(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�
s

	


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

dS(NR�
RAR�
shello world(R�
R�
R�
R�
R9(ROR�
RAR&R�((s1/usr/lib64/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�
iRAR�
RTRshello world(RR�
R�
R�RR�
R�
t
get_serverR�
tlistenerR�R_RXR�
RbR�
R.RaR�
(RRAR&tsrvrtaddrRdR�((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_rapid_restart>s$


!

	


$












(R"R#R�R�
R�
(((s1/usr/lib64/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�(ROtconntmsg((s1/usr/lib64/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(NRTRi
g@shello worldi
RwiR%iit
 i(sexpected BufferTooShort, got %sg�������?t
Xiiiii
(+RyRXR�
RYRDR_RR)
R.
RsR=R.R]tfilenoRlRrR|R�
R�
R^RGtrecv_bytes_intotitemsizet	bytearrayRjtBufferTooShortRR�RRzRZR,RR�RRfR�
R�treadabletwritableR�tEOFErrorRb(RR�
R�RdR+
R�
tlongmsgR/
tbufferRR0RcRztreally_big_msg((s1/usr/lib64/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(NRxi
R%i(
RyRZR.RrRR|R=R�
RYR�
R�tIOErrorRz(Rtreadertwriter((s1/usr/lib64/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(NRTRRQ(
RyRXR�
RYRDR_R�R)
R�
R.R�
R�
Rb(RR�
R�RdR�
((s1/usr/lib64/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>R?R)
RyR�
R.R�
R�R(RR�
R*R+((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_sendbytes�s&








cCsHytj
|
�

Wn,tk
r?
}
|jtjkr9tS�nXtSdS(
N(RtfstattOSErrorterrnotEBADFRZRY(ROtfdRc((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt_is_fd_assigned�s




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

dS(Nii
(RsR�
Rtdup2R�
Rtrecv_handletmsvcrttopen_osfhandletO_WRONLYR�R�(ROR�
tdatatcreate_dummy_fdsRwR�
((s1/usr/lib64/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 processesRxRTRR�
twbtrb(R=R>RyRYRXR�
RDR_R�RR�R�R�R�
R�
t
get_osfhandleRtsend_handleRNRbR.R�(RR�
R�RdR�R�
((s1/usr/lib64/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 processesRxRTRR�
R�
i
s2could not find an unassigned large file descriptorR�
(R=R>RyRYRXR�
RDR_R�RR�R�R�R�
RstMAXFDR�
R�RR�
RR�
RNR�RbR.R�(RR�
R�RdR�R�
tnewfd((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_large_fd_transfers(	

$
	















cCstj
|
j�d
�
dS(Ns
(RR�R�
(RR�
((s1/usr/lib64/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 processesRxRTR(
R=R>RyRYRXRRDR_R�R�RR�
Rb(RR�
R�Rd((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_missing_fd_transferCs


	



(R%R'(R"R#R3R�R�
R�
R�
R�
R�
R�
RZR�
Rt
skipUnlesst
HAS_REDUCTIONR�
R;
R�tplatformR�
R�RR
RR(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�
\s(	L	
		 







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

|j�
dS(NRQ(t
connectiontClientRrR�(ROR�
R�
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyRPVs


c
Cs�x�|jj
D]�}
|jjd
|
�
}|jd|jd|jf
�}t|_|j�
|j	�}|j
|j�d�
|j�
|j
�
q
WdS(NtfamilyRTRRQ(RtfamiliestListenerRXRPR�
RYRDR_tacceptR.R|RbR�(RR
t
lRdR�
((s1/usr/lib64/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(NRTRi
RQ(RRRXRPR�
RYRDR_RRfR
R.R|R�Rb(RRRdR�
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_issue14725gs

!
	









(R%R'(R"R#R3R�RPRR(((s1/usr/lib64/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�RltrandomtlognormvariateRjtheapt
BufferWrapperR{RGt	randranget_heapt_lockR�R�R�t_len_to_seqR
t_arenastindext_allocated_blockstsortRsRB(Rt
iterationst	maxblockstblocksRwR1
R+RR�
Rt
LtarenaR_R�tnarenatnstarttnstop((s1/usr/lib64/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_thresholdRsRjRRtbuddy(Rt
thresholdsRwR*R+((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_free_from_gc�s








	
(
R%(R"R#R3R(R0(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�s	't_FoocBs eZ
defd
efgZRS(R
R
(R"R#RRt_fields_(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR1s	
t_TestSharedCTypescBsDeZ
dZd
�Zed��
Zed�
Zd�Zd�Z	RS(R%c

Csts|j
d
�

ndS(Ns%requires multiprocessing.sharedctypes(R

R>(
R((s1/usr/lib64/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
RsRG(ROR
R
R�
R/
tstringRw((s1/usr/lib64/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(NRwiR�g�?g@iiR	
i
R;iRQRTRig@ig@t
hellohello(RRR1R-
RsR)
R/RXR5RYRDR_RbR.R)R
R
(	RR�R
R
R�
R/
R4RdRw((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_sharedctypes0s"





*
	









c

Cs|jd
t
�

dS(NR�(R7RY(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_synchronizeEs
c
CsWtd
d�}
t
|
�
}d|
_d|
_|j|jd
�
|j|jd�
dS(Nig@i(R1RR
R
R.R)(RR�
R�
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt	test_copyHs


	
	

(
R%(
R"R#R3R
R�R5RZR7R8R9(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR3s	
	t
_TestFinalizecBsAeZ
dZd
�Zd�Zed��
Zd�Zd�ZRS(R%c

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

c

Cs'|jt
j�

t
jj|j�

dS(
N(R
RR;tupdateR<(
R((s1/usr/lib64/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#(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�
bs
RR*R+R;td10texitpriorityi
td01itd02td03Rci����tSTOPi����(
R*(
R+(
R;(
R?(
RA(
RB(
RC(
Rc(
RD(	R�RtFinalizeRrRt_exit_functionR�Rt_exit(ROR�
R�
R*R+tclose_bR;R?RARBRC((s1/usr/lib64/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(NRTRRDR*R+R?RCRBRARc(
RyRXRIRYRDR_RbR�R|R.(RR�
R�RdR�R~((s1/usr/lib64/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((((s1/usr/lib64/python2.7/test/test_multiprocessing.pytcb�s
R�
cseZ
�f
d�ZRS(
c

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

dS(NR@i
id(R�RRERtrandint(
R(
RK(s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�s
	(R"R#R((
RK(s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�
�s
c
sYxR�
sTtj
tj�d
�

ytj�
Wqtk
rP
}
�j|�

qXqWdS(Ng�������?(RRfRRt_run_finalizersR�
R{(
Rc(texctfinish(s1/usr/lib64/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(((RC
Rw(
R�
(s1/usr/lib64/python2.7/test/test_multiprocessing.pys	<setcomp>�s	i
i(RsRtgetrandbitsR�
R{R
(R	
Rc(R�
RNRO(s1/usr/lib64/python2.7/test/test_multiprocessing.pytmake_finalizers�s

	
-



i
iRTg@i(R�RZR�tgetcheckintervalR�
R,tsetcheckintervalR-R�R�Rt
start_threadsRRfRYR�
(RRPRRtold_intervalt
old_thresholdR'((R�
RKRNROs1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_thread_safety�s*	


















(
R%(	R"R#R3R
R>R�RIRJRX(((s1/usr/lib64/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(NRjsmultiprocessing.connectionsmultiprocessing.heapsmultiprocessing.managerssmultiprocessing.poolsmultiprocessing.processsmultiprocessing.synchronizesmultiprocessing.utilsmultiprocessing.reductionsmultiprocessing.sharedctypest__all__s%r does not have attribute %r((
RR{RRR�R�tmodulestgetattrRBR�(RR[RMtmodtattr((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_import�s











(
R%(R"R#R3R_(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyRY�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(
Rjt
get_loggertsetLevelRt
SUBWARNINGRBRtdebugtinfot	LOG_LEVEL(Rtlogger((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_enable_logging�s







cCs#tj
�}|
j|j��

dS(
N(RjRaRrtgetEffectiveLevel(ROR�
Rg((s1/usr/lib64/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%RxRTRtlevel(RjRatloggingt	getLoggerRkRyRZRbRXRjRYRDR_R.R|tNOTSETRf(	RtLEVEL1tLEVEL2Rgtroot_loggert
root_levelR�
R�
Rd((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt
test_level�s&



	


	






	




(
R%(R"R#R3RhR�RjRs(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR`�s	t_TestPollEintrcBsAeZ
dZed
��
Zejeed�d�d��
Z	RS(R%cCs$tj
d
�

tj|
tj�
dS(Ng�?(RRfRtkilltsignaltSIGUSR1(RORN((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt_killer2	s

Rwsrequires 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(
RY(
R(
t
got_signal(s1/usr/lib64/python2.7/test/test_multiprocessing.pytrecord:	s
RTRi
i(
i
(RZRRIRvRwRXRxR_RRfRbRBR.RJ(RRzRNt
oldhandlertkillerRd((
Rys1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_poll_eintr7	s	













(
R%(
R"R#R3R�RxRRR�RvR}(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyRt.	stTestInvalidHandlecBs#eZ
ejed�d
��
ZRS(sskipped on Windowsc
Cs<tj
d
�
}
|jt|
j�
|jttj
d�
dS(Ni�M�i����(Rt
ConnectionR�R�
Rz(RR�
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_invalid_handlesP	s

(R"R#RR;
tWIN32R�(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR~N	scCs[i}xN|
D]F}t||�}t
|�
t
t�
krIt|�
}n|||<q
W|S(
N(R\R]tget_attributeststaticmethod(tSourcetnamesR	
RMR�((s1/usr/lib64/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#(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�m	s
(	tglobalst
capitalizeRF
t
startswithR3RtTestCaseR"R#(	tMixinR]R~tglobtTypeRMtbasetnewnameR�((s1/usr/lib64/python2.7/test/test_multiprocessing.pytcreate_test_casesc	s

	








	

tProcessesMixincBs0eZ
dZejZe�jeed��

RS(R%RVR�R�R�R�R�RWRR-
R
R,
R@R\RyRR�Rw
(RVR�R�R�R�R�RWRR-
R
R,
R@R\RyRR�Rw
(R"R#R=RjRXtlocalsR=R�(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�x	s

	




R]R%tManagerMixincBsEeZ
dZejZejejj�
Z	e
�jee	d��

RS(R&RVR�R�R�R�R�RWRR-
R^RD
RO
R�Rw
(RVR�R�R�R�R�RWRR-
R^RD
RO
R�Rw
(
R"R#R=RjRXR�RW
tmanagerstSyncManagerR&R�R=R�(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR��	s

	




R&tThreadsMixincBs6eZ
dZejjZe�jeejd��

RS(R'RVR�R�R�R�R�RWRR-
R@R\RyRRD
R^RO
R�Rw
(RVR�R�R�R�R�RWRR-
R@R\RyRRD
R^RO
R�Rw
(	R"R#R=RjtdummyRXR�R=R�(((s1/usr/lib64/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((RR1
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�
�	s
c
SsdS(
N((RR�
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�
�	s
(R"R#R�
R�
(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR��	s
	tabc(R�R�RjtAuthenticationErrorRtdeliver_challenge(RR�((s1/usr/lib64/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((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�	s
cSs?|jd
7_|jd
kr(t
jjS|jdkr;dSdS(Ni
issomething bogusR�
(R�RjRt	CHALLENGE(RR1
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�
�	s






c
SsdS(
N((RR�
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�
�	s
(R"R#RR�
R�
(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR��	s
		R�(R�R�RjR�Rtanswer_challenge(RR�((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt"test_answer_challenge_auth_failure�	s

	
(R"R#R�R�(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR��	s	
c

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

Cs1tj
�|_|jj�|_d
|j_dS(Ni(RjtManagertmgrRO
R�R�(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR
�	s


c


Cs|jj
�
dS(
N(R�R�
(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR>�	s
c
Cs_tj
j�}
|jt|
jd
�
|
jt|jf
�
|j|jj	d
�
|
j
�
dS(Ni
(RjR�R�R�t	TypeErrorR_R�R�R.R�R�
(Rt
m((s1/usr/lib64/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�RjRw
R�R�R�RbR.R�(RRd((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_pool_initializer�	s







(R"R#R
R>R�R�(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR��	s
			c
Cs1y|jd
t
�
}
Wntjk
r,


n
XdS(Ntblock(RaRZRVR�(R:titem((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt_this_sub_process�	s



c
CsHtj
�}
tjd
td|
f
�}t|_|j�
|j�
dS(NRTR(RjRVRXR�RYRDR_Rb(R:R�tsubProc((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt
_test_process�	s



	


c

Cs||S(
N((
R
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt_afunc�	s
c	Cs=tj
d
d�
}|jtdddddddg�}
dS(	NR%ii
iiiii(RjRw
Rc
R�(R^
R
((s1/usr/lib64/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((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�	s
	
c
Cs7tj
�}
|
|jkr0|
|_g|_n|jS(
N(RRIR�t_cache(RRN((s1/usr/lib64/python2.7/test/test_multiprocessing.pytcache�	s

	

cCs|jj
|
�

dS(
N(R�R{(RR�
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�
s
c

Cs)|jj
d
j|j�
�

g|_dS(NR�
(R�R�RbR�R�(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pytflush
s

(R"R#RtpropertyR�R�R�(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR��	s
			tTestStdinBadfiledescriptorc
Bs#eZ
d�Zd
�Zd�ZRS(c
Cs?tj
�}
tjd
td|
f
�}|j�
|j�
dS(NRTR(RjRVRXR�R_Rb(RR�R�((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_queue_in_process
s




c
Cs*tj
d
t�
}
|
j�
|
j�
dS(NRT(RjRXR�R_Rb(RRd((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_pool_in_process
s



c
sKt�}
t
|
�
��jd
�

tjd�f
d��
}�j�
dS(NR�
RTc
s
�j�S(
N(
R�((
tflike(s1/usr/lib64/python2.7/test/test_multiprocessing.pyR

R�
(R
R�R�RjRXR�(RtsioR�((
R�s1/usr/lib64/python2.7/test/test_multiprocessing.pyt
test_flushing
s
	






(R"R#R�R�R�(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�

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

|
jd�

|
j�
tjj|�
}|jd�

|j�
dS(Ni
i{i�
(RRfRrR�RjRR	(ROtchildR�
R�
((s1/usr/lib64/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�������?RxR
tAF_INETRTRi{i�
i
(tsockettgetdefaulttimeouttsetdefaulttimeoutRjRyRYRRRXR�R�
R_R�R.R|R
Rb(Rtold_timeouttparentR�RRdR�
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�-
s"





















(R"R#R�R�R�(((s1/usr/lib64/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(
RtpathRbtdirnamet__file__R�R�t
script_helpertassert_python_failureR.R`tassert_python_okR�(RRMtrctoutterr((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_noforkbombF
s
!





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

dS(
N(RrR�
R�tflags(ROR�
((s1/usr/lib64/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����RxRTR(tjsonRjRyRZRXR�R_R|RbR�R�
R�R�tdumps(ROR�R�R�Rdtgrandchild_flagsR�((s1/usr/lib64/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�((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt
test_flagsg
s




(R"R#R�R�R�Rtrequires_unicodeR�(((s1/usr/lib64/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
RTR(
RjRXR�R_RbRrRGRt_afterfork_registryR�(RORQ
R�
Rd((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR�{
s
%




c
Cs�tj
t�
\}
}tj�}ttj�
}tjd
|jdd|f�}|j	�
|
j
�}|j�
|j||�
dS(NRTRi(
RjRyRZRtForkAwareThreadLockRGR�RXR�R_R|RbtassertLessEqual(RR�R�Rtold_sizeRdtnew_size((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR��
s



!





(R"R#R�R�R�(((s1/usr/lib64/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((s1/usr/lib64/python2.7/test/test_multiprocessing.pythandler�
s
treadyR
(RvRwRrR|R�
t
CONN_MAX_SIZE(ROR�
R�R
((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt_test_ignore�
s	





Rwsrequires 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(NRTRR�g�������?i�R
(RjRyRXR�RYRDR_R�R.R|RRfRRuRNRvRwRrR�
R�Rb(RR�
R�Rd((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_ignore�
s&



	



















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

|j�}|jd�

dS(Nc
SsdS(
N((R�R�((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR��
s
twelcome(RvRwRjRRRrR�
R
(ROR�
R�RR*((s1/usr/lib64/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(NRTRg�������?R�(RjRyRXR�RYRDR_R�R|RRfRRuRNRvRwRR	R.Rb(RR�
R�RdR�
tclient((s1/usr/lib64/python2.7/test/test_multiprocessing.pyttest_ignore_listener�
s



	












(R"R#tmaxRt
PIPE_MAX_SIZEt
SOCK_MAX_SIZER�R�R�RRR�RvR�R�R�(((s1/usr/lib64/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((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR
�
R�
c


Ss|jS(
N(
R"(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR
�
R�
c


Ss|jS(
N(
R"(
R((s1/usr/lib64/python2.7/test/test_multiprocessing.pyR
�
R�
c
3s|]}
�|
�
V
qdS(
N((RC
R(
tloadTestsFromTestCase(s1/usr/lib64/python2.7/test/test_multiprocessing.pys	<genexpr>ss%.+__(get|set)slice__ has been removedssys.exc_clear\(\) not supportedtquiet()R�RR�RjR�R�
RRRRttest.supportR�Rtget_temp_dirRaRbRfRw
R�R^
R�R�R�R&RR_RE
ttestcases_processesR
ttestcases_threadsttestcases_managerttestcases_othertdefaultTestLoaderR
t	TestSuiteRtcheck_py3k_warningstDeprecationWarningRYRhR�
(R�R�t	testcasestsuite((
R
s1/usr/lib64/python2.7/test/test_multiprocessing.pyt	test_main�
s:













J


	










cCstt
jd
d�
j�

dS(Nt	verbosityi(RRtTextTestRunnerR�(((s1/usr/lib64/python2.7/test/test_multiprocessing.pytmains
t__main__(g=
ףp=�?gffffff�?gffffff�?(g�������?g�������?g�������?(R�R�
(�RRVRR�RR�
RvR.
R�RRlR�
R�ttest.script_helperR�RR
t
import_moduleRR�tmultiprocessing.dummyRjtmultiprocessing.connectiontmultiprocessing.managerstmultiprocessing.heapR�
RRRYRtImportErrorRZtmultiprocessing.sharedctypesRRR

R�
RR�R)
RcRfRoR(R�R�R�R\t
HAVE_GETVALUERR�RR�
tctypesR
RRR�RRR$R5R8R<RXR�R�R�R�R�R�R�R�R
R
R*
R<
RS
RT
RU
RRY
R\
R]
R�
R�
R�
R�
R�
R�
R�
R�
R�
R�
R�
tregisterR�
R�
R�
R�
R�
R�
R�
R�
R�
R�
RRR1R3R:RYR`RtR�R~R�R�R�RR�R=R�RR�RR�R�R�R�R�R�R�R�R�R�R�R�R�R�RRRR"(((s1/usr/lib64/python2.7/test/test_multiprocessing.pyt<module>s$








































	








 



		�		�6�-EZS	
	�	2		

$
	
4&��E6v!C 			





!					"!G	
	
0