ó n®¸Qc@s›dZddlZddlZddlmZddlZddlmZmZmZdej fd„ƒYZ d„Z e dkr—ej d d ƒndS( s& TestCases for exercising a Queue DB. iÿÿÿÿN(tpprint(tdbtverbosetget_new_database_pathtSimpleQueueTestCasecBs,eZd„Zd„Zd„Zd„ZRS(cCstƒ|_dS(N(Rtfilename(tself((s+/sys/lib/python2.7/bsddb/test/test_queue.pytsetUpscCs/ytj|jƒWntjk r*nXdS(N(tostremoveRterror(R((s+/sys/lib/python2.7/bsddb/test/test_queue.pyttearDownscCs{tr%dGddGHd|jjGHntjƒ}|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ƒtrMdddGHt |j ƒƒn|jƒ~tjƒ}|j|jƒtrœdddGHt |j ƒƒn|jddƒ|jdddƒ|jƒ}trñdddGHt |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 orderisreplacement datais before closes after opensone mores another 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__RtDBt set_re_lentopenRtDB_QUEUEt DB_CREATERtstattstringtletterstappendt assertEqualtlentputtclosetNonetcursortconsume(Rtdtxtctrec((s+/sys/lib/python2.7/bsddb/test/test_queue.pyt test01_basicsZ    #          cCs6tr%dGddGHd|jjGHntjƒ}|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ƒtrMdddGHt |j ƒƒn|jƒ~tjƒ}|j|jƒtrœdddGHt |j ƒƒn|jdƒtrÏdddGHt |j ƒƒn|jƒ}x$|rtrò|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 orderisreplacement datais before closes after opensone mores after appendsafter consume loop(RRRRRRRRRRRRRRRRRRRR(RR R!R#((s+/sys/lib/python2.7/bsddb/test/test_queue.pyttest02_basicPost32^sP    #         (Rt __module__RR R$R%(((s+/sys/lib/python2.7/bsddb/test/test_queue.pyR s   FcCs tjtƒS(N(tunittestt makeSuiteR(((s+/sys/lib/python2.7/bsddb/test/test_queue.pyt test_suitežst__main__t defaultTestR)(t__doc__RRRR'ttest_allRRRtTestCaseRR)Rtmain(((s+/sys/lib/python2.7/bsddb/test/test_queue.pyts ‘