Ñò
•à"Ic           @   s   d  Z  d d k Z d d k Z d d k l Z d d k Z d d k l Z l Z l Z d e i	 f d „  ƒ  YZ
 d „  Z e d j o e i d	 d
 ƒ n d S(   s&   
TestCases for exercising a Queue DB.
iÿÿÿÿN(   t   pprint(   t   dbt   verboset   get_new_database_patht   SimpleQueueTestCasec           B   s,   e  Z d  „  Z d „  Z d „  Z d „  Z RS(   c         C   s   t  ƒ  |  _ d  S(   N(   R   t   filename(   t   self(    (    s2   /mit/python/lib/python2.6/bsddb/test/test_queue.pyt   setUp   s    c         C   s1   y t  i |  i ƒ Wn t  i j
 o n Xd  S(   N(   t   ost   removeR   t   error(   R   (    (    s2   /mit/python/lib/python2.6/bsddb/test/test_queue.pyt   tearDown   s    c         C   s‹  t  o  d Gd d GHd |  i i GHn t i ƒ  } | i d ƒ | i |  i t i t i	 ƒ t  o! d d d GHt
 | i ƒ  ƒ n x" t i D] } | i | d ƒ qŽ W|  i t | ƒ t t i ƒ ƒ | i d d	 ƒ | i d
 d ƒ | i d d ƒ | i d d ƒ |  i t | ƒ t t i ƒ d ƒ t  o! d d d GHt
 | i ƒ  ƒ n | i ƒ  ~ t i ƒ  } | i |  i ƒ t  o! d d d GHt
 | i ƒ  ƒ n | i d d  ƒ | i d d d  ƒ| i ƒ  } t  o! d d d GHt
 | i ƒ  ƒ n | i ƒ  } x( | o  t  o	 | GHn | i ƒ  } q
W| i ƒ  t  o! d d d GHt
 | i ƒ  ƒ n |  i t | ƒ d d ƒ | i ƒ  d  S(   Ns   
s   -=i   s   Running %s.test01_basic...i(   s   before appendst   -id   s   some more dataie   s   and some more iK   s   out of orderi   s   replacement datai   s   before closes
   after opens   one mores   another onet   txns   after appends   after consume loopi    sk   if you see this message then you need to rebuild Berkeley DB 3.1.17 with the patch in patches/qam_stat.diff(   R   t	   __class__t   __name__R   t   DBt
   set_re_lent   openR   t   DB_QUEUEt	   DB_CREATER    t   statt   stringt   letterst   appendt   assertEqualt   lent   putt   closet   Nonet   cursort   consume(   R   t   dt   xt   ct   rec(    (    s2   /mit/python/lib/python2.6/bsddb/test/test_queue.pyt   test01_basic   s^    
 #
 	
c         C   sn  t  o  d Gd d GHd |  i i GHn t i ƒ  d j  o t  o	 d GHn d  St i ƒ  } | i d	 ƒ | i |  i t i	 t i
 ƒ t  o! d
 d d GHt | i ƒ  ƒ n x" t i D] } | i | d	 ƒ q¶ W|  i t | ƒ t t i ƒ ƒ | i d d ƒ | i d d ƒ | i d d ƒ | i d d ƒ |  i t | ƒ t t i ƒ d ƒ t  o! d d d GHt | i ƒ  ƒ n | i ƒ  ~ t i ƒ  } | i |  i ƒ t  o! d d d GHt | i ƒ  ƒ n | i d ƒ t  o! d d d GHt | i ƒ  ƒ n | i ƒ  } x( | o  t  o	 | GHn | i ƒ  } qWt  o! d d d GHt | i ƒ  ƒ n | i ƒ  d  S(   Ns   
s   -=i   s    Running %s.test02_basicPost32...i   i   i    s"   Test not run, DB not new enough...i(   s   before appendsR   id   s   some more dataie   s   and some more iK   s   out of orderi   s   replacement datas   before closes
   after opens   one mores   after appends   after consume loop(   i   i   i    (   R   R   R   R   t   versionR   R   R   R   R   R   R    R   R   R   R   R   R   R   R   R   (   R   R    R!   R#   (    (    s2   /mit/python/lib/python2.6/bsddb/test/test_queue.pyt   test02_basicPost32^   s\    	
 #
 	(   R   t
   __module__R   R   R$   R&   (    (    (    s2   /mit/python/lib/python2.6/bsddb/test/test_queue.pyR      s   			Fc           C   s   t  i t ƒ S(   N(   t   unittestt	   makeSuiteR   (    (    (    s2   /mit/python/lib/python2.6/bsddb/test/test_queue.pyt
   test_suite£   s    t   __main__t   defaultTestR*   (   t   __doc__R   R   R    R(   t   test_allR   R   R   t   TestCaseR   R*   R   t   main(    (    (    s2   /mit/python/lib/python2.6/bsddb/test/test_queue.pyt   <module>   s   –	