数据库发生错误。

�
zfc@sM
dd
lZdd
l
Z
dd
lZddlmZ
ejd�
ZdZdejf
d��YZ	ddd��YZ
d	e
f
d
��YZdeejfd��YZ
d
eejfd��YZdeejfd��YZdef
d��YZdejf
d��YZde
ejfd��YZd�ZedkrI
e�
nd
S(i����N(
ttest_supportt	threadingit_TriggerThreadc
BseZ
d�Zd
�ZRS(cCs5|
|_||_
tj�|_tjj|�

dS(
N(tfntargsR
tEventtstartedEventtThreadt__init__(tselfRR((s'/usr/lib64/python2.7/test/test_queue.pyR
s
	
	

c

Cs.tj
d
�

|jj�
|j|j�
dS(Ng�������?(ttimetsleepRtsetRR(
R	((s'/usr/lib64/python2.7/test/test_queue.pytruns	



(t__name__t
__module__RR
(((s'/usr/lib64/python2.7/test/test_queue.pyRs
	tBlockingTestMixinc
Bs#eZ
d�Zd
�Zd�ZRS(c

Cs
d|_
dS(
N(tNonet
t(
R	((s'/usr/lib64/python2.7/test/test_queue.pyttearDown.s
cCs�t||�|_
|j
j�
|
|�|_|j
jj�sT|jd
|
�

n|j
jd�

|j
j�r�|jd|�

n|jS(Ns,blocking function '%r' appeared not to blocki
s,trigger function '%r' appeared to not return(	RRtstarttresultRtis_settfailtjointis_alive(R	t
block_funct
block_argsttrigger_functtrigger_args((s'/usr/lib64/python2.7/test/test_queue.pytdo_blocking_test1s




	



	

cCs�t||�|_
|j
j�
z:y|
|�
Wn|k
rF


�nX|jd
|�

Wd|j
jd�

|j
j�r�|jd|�

n|j
jj�s�|jd�

nXdS(Nsexpected exception of kind %ri
s,trigger function '%r' appeared to not returns(trigger thread ended but event never set(RRRRRRRR(R	RRRRtexpected_exception_class((s'/usr/lib64/python2.7/test/test_queue.pytdo_exceptional_blocking_test@s







	


	


(RRRRR (((s'/usr/lib64/python2.7/test/test_queue.pyR,s		t
BaseQueueTestc
BsGeZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�ZRS(c

Csd
|_t
j�|_dS(Ni(tcumR
tLocktcumlock(
R	((s'/usr/lib64/python2.7/test/test_queue.pytsetUpVs
	
c	Cs�|
j�st
d
�n|
jd�

|
jd�

|
jd�

tddddgddddgddddg�}|
j�|
j�|
j�g}|j|||
jjd�
x<tt	d	�
D]*}|
j|�

|j
|
j�d
�
q�W|j
|
j�d�
dt	}dt	}|
j|�

|j
|
j�d�
y$|
j|dd�


|jd�

Wnt
jk
rz



n
Xy$|
j|dd�


|jd�

Wnt
jk
r�



n
X|j|
j|f
|
jd�
|j|
j|tdf|
jd�
xtt	�
D]}|
j�
qW|j
|
j�d�
y!|
jdd�

|jd�

Wnt
jk
rh


n
Xy!|
jdd�

|jd�

Wnt
jk
r�


n
X|j|
jd|
jd�
|j|
jtdf|
jd�
dS( Ns&Call this function with an empty queueioiM
i�tQueuet	LifoQueuet
PriorityQueues&Didn't seem to queue the correct data!i
sQueue should not be emptysQueue should not be fulliisQueue should be fulltblockis(Didn't appear to block with a full queuettimeoutg{�G�z�?s+Didn't appear to time-out with a full queuei
sQueue should be emptys*Didn't appear to block with an empty queues-Didn't appear to time-out with an empty queuetemptyi((((
R+(
R+(R+tRuntimeErrortputtdicttgettassertEqualt	__class__Rtranget
QUEUE_SIZEt
assertTruetfullRR&tFullRtTruetEmpty(R	t
qttarget_ordertactual_ordert
itlastR5((s'/usr/lib64/python2.7/test/test_queue.pytsimple_queue_testZs\










!
























%












cCs`xYtr[|
j
�}|dkr/|
j�
dS|j�
|j|7_WdQX|
j�
qWdS(
N(R7R/Rt	task_doneR$R"(R	R9t
x((s'/usr/lib64/python2.7/test/test_queue.pytworker�s
	








cCs�d
|_x0dD](}t
jd|jd|
f
�j�
qWx!td�
D]}|
j|�

qIW|
j�
|j|jt	t
d�
�
d�
xdD]}|
jd�

q�W|
j�
dS(	Nii
ttargetRids0q.join() did not block until all tasks were done(ii
(ii
(R"R
RRARtxrangeR-RR0tsumR2R(R	R9R<((s'/usr/lib64/python2.7/test/test_queue.pytqueue_join_test�s
	


&









c
Cs?|j�}
y|
j
�
Wntk
r-


nX|jd
�

dS(Ns(Did not detect task count going negative(t	type2testR?t
ValueErrorR(R	R9((s'/usr/lib64/python2.7/test/test_queue.pyttest_queue_task_done�s




c
CsY|j�}
|j
|
�

|j
|
�

y|
j�
Wntk
rG


nX|jd
�

dS(Ns(Did not detect task count going negative(RFRER?RGR(R	R9((s'/usr/lib64/python2.7/test/test_queue.pyttest_queue_join�s








c
Cs-|jt
�
}
|j|
�

|j|
�

dS(
N(RFR3R>(R	R9((s'/usr/lib64/python2.7/test/test_queue.pyttest_simple_queue�s


(	RRR%R>RARERHRIRJ(((s'/usr/lib64/python2.7/test/test_queue.pyR!Us
		5	
	
	
	
t	QueueTestc
BseZ
ejZRS((RRR&RF(((s'/usr/lib64/python2.7/test/test_queue.pyRK�s
t
LifoQueueTestc
BseZ
ejZRS((RRR&R'RF(((s'/usr/lib64/python2.7/test/test_queue.pyRL�s
tPriorityQueueTestc
BseZ
ejZRS((RRR&R(RF(((s'/usr/lib64/python2.7/test/test_queue.pyRM�s
tFailingQueueExceptionc
BseZ
RS((RR(((s'/usr/lib64/python2.7/test/test_queue.pyRN�s
tFailingQueuec
Bs#eZ
d�Zd
�Zd�ZRS(c
Gs)t|_
t|_tjj||
�

dS(
N(tFalset
fail_next_putt
fail_next_getR&R(R	R((s'/usr/lib64/python2.7/test/test_queue.pyR�s
	
	
cCs1|jrt
|_td
�ntjj||
�S(NsYou Lose(RQRPRNR&t_put(R	titem((s'/usr/lib64/python2.7/test/test_queue.pyRS�s
	
	

c

Cs.|jrt
|_td
�ntjj|�
S(NsYou Lose(RRRPRNR&t_get(
R	((s'/usr/lib64/python2.7/test/test_queue.pyRU�s
	
	

(RRRRSRU(((s'/usr/lib64/python2.7/test/test_queue.pyRO�s
		tFailingQueueTestc
BseZ
d�Zd
�ZRS(cCs�|
j�st
d
�nx%ttd�
D]}|
j|�

q)Wt|
_y$|
jddd�


|jd�

Wntk
r�


n
Xt|
_y$|
jddd�


|jd�

Wntk
r�


n
X|
jd	�

|j	|
j
�d
�
t|
_y-|j|
jd|
jd�
|jd�

Wntk
r.



n
X|
jd	�

t|
_y9|j
|
jdtdf|
jdt�
|jd�

Wntk
r�



n
X|
jd	�

|j	|
j
�d
�
|
j�
|j	|
j
�d
�
|
jd	�

|j	|
j
�d
�
|j|
jd|
jd�
xtt�
D]}|
j�
q"W|j	|
j�d�
|
jd�

t|
_y|
j�
|jd�

Wntk
r�


n
X|j	|
j�d�
t|
_y!|
jdd�

|jd�

Wntk
r�


n
X|j	|
j�d�
|
j�
|j	|
j�d�
t|
_y0|j
|
jd|
jdt�
|jd�

Wntk
ri


n
X|j	|
j�d�
|
j�
|j	|
j�d�
dS(Ns&Call this function with an empty queuei
toopsR)is)The queue didn't fail when it should haveR*g�������?R=sQueue should be fullR5i
sQueue should not be fullsQueue should be emptytfirstsQueue should not be emptyR+(
R5(((
R5(((
R+(R+R,R2R3R-R7RQRRNR4R5RR/R RR(R	R9R<((s'/usr/lib64/python2.7/test/test_queue.pytfailing_queue_test�s�



	






	








	






	

!

















	








	










	









c
Cs*tt
�
}
|j|
�

|j|
�

dS(
N(ROR3RY(R	R9((s'/usr/lib64/python2.7/test/test_queue.pyttest_failing_queue7
s


(RRRYRZ(((s'/usr/lib64/python2.7/test/test_queue.pyRV�s	QcCstj
tttt�
dS(
N(Rtrun_unittestRKRLRMRV(((s'/usr/lib64/python2.7/test/test_queue.pyt	test_main?
s

t__main__((R&R
tunittestttestRt
import_moduleR
R3RRRR!tTestCaseRKRLRMt	ExceptionRNRORVR\R(((s'/usr/lib64/python2.7/test/test_queue.pyt<module>s"



 )p[