�
{ fc @ s� d Z d d l Z d d l Z d d l m Z d d l Z d d l m Z m Z m Z d e j f d � � YZ
d � Z e d k r� e j
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( ( s- /usr/lib64/python2.7/bsddb/test/test_queue.pyt setUp s c C s/ y t j | j � Wn t j k
r* n Xd S( N( t ost removeR t error( R ( ( s- /usr/lib64/python2.7/bsddb/test/test_queue.pyt tearDown s c C s{ t r% d Gd d GHd | j j GHn t j � } | j d � | j | j t j t j � t r� d d d GHt
| j � � n x" t j
D] } | j | d � q� W| j t | � t t j
� � | j d d � | j d
d � | j d d
� | j d d � | j t | � t t j
� d � t rMd d d GHt
| j � � n | j � ~ t j � } | j | j � t r�d d d GHt
| j � � n | j d d � | j d d d �| j � } t r�d d d GHt
| j � � n | j � } x$ | r#t r| GHn | j � } q W| j � t rTd d d GHt
| j � � n | j t | � d d � | j � 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
ascii_letterst appendt assertEqualt lent putt closet Nonet cursort consume( R t dt xt ct rec( ( s- /usr/lib64/python2.7/bsddb/test/test_queue.pyt test01_basic sZ
#
c C s6 t r% d Gd d GHd | j j GHn t j � } | j d � | j | j t j t j � t r� d d d GHt
| j � � n x" t j
D] } | j | d � q� W| j t | � t t j
� � | j d d � | j d
d � | j d d
� | j d d � | j t | � t t j
� d � t rMd d d GHt
| j � � n | j � ~ t j � } | j | j � t r�d d d GHt
| j � � n | j d � t r�d d d GHt
| j � � n | j � } x$ | rt r�| GHn | j � } q�Wt r(d d d GHt
| j � � n | j � d S( Ns
s -=i s Running %s.test02_basicPost32...i( s before appendsR id s some more dataie s and some more iK s out of orderi s replacement datai s before closes
after opens one mores after appends after consume loop( R R R R R R R R R R R R R R R R R R R R ( R R R! R# ( ( s- /usr/lib64/python2.7/bsddb/test/test_queue.pyt test02_basicPost32^ sP
#
( R t
__module__R R R$ R% ( ( ( s- /usr/lib64/python2.7/bsddb/test/test_queue.pyR
s Fc C s
t j t � S( N( t unittestt makeSuiteR ( ( ( s- /usr/lib64/python2.7/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( ( ( s- /usr/lib64/python2.7/bsddb/test/test_queue.pyt <module> s � 