m�
�=5Dc@s�dZd
k
ad
kZd
kZd
kZd
kZdklZ
da	dei
f
d��YZdei
f
d��YZdei
f
d	��YZ
d
d
�
Zedjo
e�
n

d
S(s�Generic thread tests.

Meant to be used by dummy_thread and thread.  To allow for different modules
to be used, test_main() can be called with the module to use as the thread
implementation as its sole argument.

N(
stest_supportit	LockTestsc
Bs_tZ
dZd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�ZRS(
sTest lock objects.c

Csti
�|_dS(
N(t_threadt
allocate_locktselftlock(
R((t,/usr/lib/python2.4/test/test_dummy_thread.pytsetUpsc

Cs|i
|ii�d
�
dS(Ns(Lock object is not initialized unlocked.(Rt
failUnlessRtlocked(
R((Rt
test_initlocks
c

Cs8|i
i�
|i
i�
|i|i
i�d
�
dS(Ns%Lock object did not release properly.(RRtacquiretreleaseRR(
R((Rttest_releases




c

Cs|i
ti|ii�
dS(
N(RtfailUnlessRaisesR
terrorRR(
R((Rttest_improper_release%sc

Cs |i
|iid
�
d�
dS(Nis)Conditional acquiring of the lock failed.(RRRR
(
R((Rttest_cond_acquire_success)s
c

Cs1|i
id
�

|i|i
id
�
d�
dS(Nis=Conditional acquiring of a locked lock incorrectly succeeded.(RRR
R(
R((Rttest_cond_acquire_fail.s

c

Cs*|i
i�
|i|i
i�d
�
dS(NsUncondional locking failed.(RRR
RR(
R((Rttest_uncond_acquire_success5s


c

Cs&|i
|iid
�
tjd�
dS(Ni
s*Unconditional locking did not return True.(RRRR
tTrue(
R((Rttest_uncond_acquire_return_val;s
c
Cs�d
�}|ii�
tti��
}ti||it	f�
t
io
Hdt	GHn

|ii�
tti��
}
t
io	
dGHn

|i
|
|t	jd�
dS(NcCsti
|
�

|i�
d
S(s:Hold on to lock for a set amount of time before unlocking.N(ttimetsleeptdelayt	to_unlockR(RR((Rtdelay_unlockBs



s@*** Waiting for thread to release the lock (approx. %s sec.) ***tdones+Blocking by unconditional acquiring failed.(RRRR
tintRt
start_timeR
tstart_new_threadtDELAYttest_supporttverbosetend_timeR(RR!RR((Rttest_uncond_acquire_blocking@s	













	

(t__name__t
__module__t__doc__RR	RRRRRRR"(((RRs
								t	MiscTestsc
Bs;tZ
dZd
�Zd�Zd�Zd�Zd�ZRS(sMiscellaneous tests.c

Cs|i
tti�
dS(
N(RR
t
SystemExitR
texit(
R((Rt	test_exitXsc

Cs?|i
tti�t�d
�
|i
ti�djd�
dS(Ns*_thread.get_ident() returned a non-integeris_thread.get_ident() returned 0(RRt
isinstanceR
t	get_identR(
R((Rt
test_ident\s


c

Cs&|i
tti�ti�d
�
dS(NsR_thread.LockType is not an instance of what is returned by _thread.allocate_lock()(RRR*R
RtLockType(
R((Rt
test_LockTypecs
c
Cs)d
�}
|itti|
t��
dS(Nc
Csti
�
dS(
N(R
tinterrupt_main(((Rtcall_interruptls
(R0RR
tKeyboardInterruptR
Rttuple(RR0((Rttest_interrupt_mainis	
c

Cs|i
tti�
dS(
N(RR
R1R
R/(
R((Rttest_interrupt_in_mainqs(R#R$R%R)R,R.R3R4(((RR&Us
				tThreadTestsc
Bs tZ
dZd
�Zd�ZRS(sTest thread creation.c
Cs
ttd
�}
tid�
}ti|
|ttf�
|i�}|i
|do
|dd�
ti|
t�hd|<dt<dt<�
|i�}|i
|do
|dd�
ti|
|tfhdt<�
|i�}|i
|do
|dd	�
dS(
NcCs|i
|
|f�

d
S(s<Use to test _thread.start_new_thread() passes args properly.N(tqueuetputtarg1targ2(R6R8R9((Rt
arg_tester{s

i
is7Argument passing for thread creation using tuple failedR6R8R9s8Argument passing for thread creation using kwargs failedsGArgument passing for thread creation using both tuple and kwargs failed(tFalseR:tQueuet
testing_queueR
RRtgettresultRRR2(RR:R?R=((Rttest_arg_passingys




1


"


c
Cs�d
�}
d}ti|�
}tio
Hdt|fGHn

xPt|�
D]B}to
t	t
i
�d�}n
d}ti
|
||f�
qIWtit�

tio	
dGHn

|i|i�|jd|tf�
dS(NcCs$ti
|
�

|iti��

d
S(s@Wait for ``delay`` seconds and then put something into ``queue``N(RRRR6R7R
R+(R6R((Rt
queue_mark�s



isJ*** Testing multiple thread creation (will take approx. %s to %s sec.) ***i
iRs2Not all %s threads executed properly after %s sec.(RAtthread_countR<R=RR Rtxrangetcounttroundtrandomtlocal_delayR
RRRRRtqsize(RRARBRDRGR=((Rttest_multi_creation�s$	









	





	

(R#R$R%R@RI(((RR5vs
	c

CsF|o
|a
d
an

tio
Hdt
GHn

tittt�
dS(Nis"*** Using %s as _thread module ***(	timported_moduleR
RRR trun_unittestRR&R5(
RJ((Rt	test_main�s











t__main__(R%tdummy_threadR
RR<RFtunittestttestRRtTestCaseRR&R5tNoneRLR#(	RRORFR5R<RLR&RR((Rt
?s
	
	
	
	
	

C!4