��Qc@s�dZd
dl
Z
d
dlZd
dlmZ
d
dlZd
dlmZmZmZ
dej	f
d��YZ
d�Zedkr�ej
d	d
�

ndS(s&
TestCases for exercising a Queue DB.
i�N(
tpprint(tdbtverbosetget_new_database_pathtSimpleQueueTestCasec
Bs,eZ
d�Zd
�Zd�Zd�ZRS(c

Cst�|_
dS(
N(Rtfilename(
tself((s+/sys/lib/python2.7/bsddb/test/test_queue.pytsetUps
c

Cs/ytj
|j�
Wntjk
r*


n
XdS(
N(tostremoveRterror(
R((s+/sys/lib/python2.7/bsddb/test/test_queue.pyttearDowns



c
Cs{tr%d
GddGHd|j
jGHntj�}
|
jd�
|
j|jtjtj	�
tr�dddGHt
|
j��
nx"tj
D]}|
j|d�
q�W|jt|
�ttj
��
|
jdd	�
|
jd
d�
|
jdd
�
|
jdd�
|jt|
�ttj
�d�
trM
dddGHt
|
j��
n|
j�
~
tj�}
|
j|j�
tr�dddGHt
|
j��
n|
jdd�
|
jddd�

|
j�}tr�ddGHt
|
j��
n|j�}x$|r#tr|GHn|j�}qW|j�
trTdddGHt
|
j��
n|jt|
�dd�
|
j�
dS(Ns

s-=isRunning %s.test01_basic...i(sbefore appendst
-idssome more dataiesand some more iKsout of orderi
sreplacement dataisbefore closes
after opensone moresanother onettxnsafter appendsafter consume loopiskif you see this message then you need to rebuild Berkeley DB 3.1.17 with the patch in patches/qam_stat.diff(Rt	__class__t__name__R
tDBt
set_re_lentopenRtDB_QUEUEt	DB_CREATERtstattstringtletterstappendtassertEqualtlentputtclosetNonetcursortconsume(Rt
dt
xt
ctrec((s+/sys/lib/python2.7/bsddb/test/test_queue.pyttest01_basicsZ












#













	








c
Cs6tr%d
GddGHd|j
jGHntj�}
|
jd�
|
j|jtjtj	�
tr�dddGHt
|
j��
nx"tj
D]}|
j|d�
q�W|jt|
�ttj
��
|
jdd	�
|
jd
d�
|
jdd
�
|
jdd�
|jt|
�ttj
�d�
trM
dddGHt
|
j��
n|
j�
~
tj�}
|
j|j�
tr�dddGHt
|
j��
n|
jd�
tr�dddGHt
|
j��
n|
j�}x$|r
tr�GHn|
j�}q�Wtr(dddGHt
|
j��
n|
j�
dS(Ns

s-=is Running %s.test02_basicPost32...i(sbefore appendsRidssome more dataiesand some more iKsout of orderi
sreplacement dataisbefore closes
after opensone moresafter appendsafter consume loop(RRRR
RRRRRRRRRRRRRRRR(RR R!R#((s+/sys/lib/python2.7/bsddb/test/test_queue.pyttest02_basicPost32^sP












#














	





(Rt
__module__RRR$R%(((s+/sys/lib/python2.7/bsddb/test/test_queue.pyR
s
			FcCs
tj
t�S(
N(tunittestt	makeSuiteR(((s+/sys/lib/python2.7/bsddb/test/test_queue.pyt
test_suite�s
t__main__tdefaultTestR)(t__doc__RRRR'ttest_allR
RRtTestCaseRR)Rtmain(((s+/sys/lib/python2.7/bsddb/test/test_queue.pyt<module>s

�