PATH:
lib64
/
python2.7
/
bsddb
/
test
� ��^c @ s� d Z d d l Z d d l Z d d l Z d d l m Z m Z m Z m Z m Z m Z e r� d d l m Z e j d d k r� d d l m Z q� d d l m Z n d e j f d � � YZ d � Z e d k r� e j d d � n d S( s/ TestCases for testing the locking sub-system. i����N( t dbt test_supportt verboset have_threadst get_new_environment_patht get_new_database_path( t Threadi i ( t currentThread( t current_threadt LockingTestCasec B s> e Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C sM t � | _ t j � | _ | j j | j t j t j Bt j Bt j B� d S( N( R t homeDirR t DBEnvt envt opent DB_THREADt DB_INIT_MPOOLt DB_INIT_LOCKt DB_CREATE( t self( ( s, /usr/lib64/python2.7/bsddb/test/test_lock.pyt setUp s c C s! | j j � t j | j � d S( N( R t closeR t rmtreeR ( R ( ( s, /usr/lib64/python2.7/bsddb/test/test_lock.pyt tearDown s c C s� t r% d Gd d GHd | j j GHn | j j � } t rF d | GHn | j j | d t j � } t rs d | GHn | j j | � t r� d | GHn | j j | � d S( Ns s -=i s Running %s.test01_simple...s locker ID: %ss some locked things Acquired lock: %ss Released lock: %s( R t __class__t __name__R t lock_idt lock_getR t DB_LOCK_WRITEt lock_putt lock_id_free( R t anIDt lock( ( s, /usr/lib64/python2.7/bsddb/test/test_lock.pyt test01_simple" s c C s� t r% d Gd d GHd | j j GHn g } | j t d | j d t j f � � | j t d | j d t j f � � | j t d | j d t j f � � | j t d | j d t j f � � | j t d | j d t j f � � | j t d | j d t j f � � | j t d | j d t j f � � | j t d | j d t j f � � | j t d | j d t j f � � xP | D]H } d d l } | j d d k r�| j t � n t | _ | j � qWx | D] } | j � q�Wd � } d S( Ns s -=i s Running %s.test02_threaded...t targett argsi����i i c S s� | j j d t j � | j | j j t j � d � | j j d t j � | j | j j t j � d � | j j d t j � | j | j j t j � d � | j j d t j � | j | j j t j � d � d S( Ni i@� i�dx ( R t set_timeoutR t DB_SET_LOCK_TIMEOUTt assertEqualt get_timeoutt DB_SET_TXN_TIMEOUT( R ( ( s, /usr/lib64/python2.7/bsddb/test/test_lock.pyt test03_lock_timeoutV s ( R R R t appendR t theThreadR R t DB_LOCK_READt syst version_infot setDaemont Truet daemont startt join( R t threadst tR, R( ( ( s, /usr/lib64/python2.7/bsddb/test/test_lock.pyt test02_threaded3 s> c s � j j d t j � � j j d t j � � j j d t j � � j j d t j � � � f d � � t � _ d � _ t d � � } d d l } | j d d k r� | j t � n t | _ | j � � j j d t j � � j j � } � j j � } � j | | � � j j | d t j � } t j � } � j t j � j j | d t j � t j � } t � _ | j d k r�d } n d } � j | | | � � j j | � | j � � j j | � � j j | � t j � d k r� j � j d � n d S( Ni i@� i�dx c sV xO � j sQ � j j t j � � _ � j rA x � j s< q0 WPn t j d � q Wd S( Ng{�G�z�?( t endR t lock_detectR t DB_LOCK_EXPIREt countt timet sleep( ( t deadlock_detectionR ( s, /usr/lib64/python2.7/bsddb/test/test_lock.pyR< f s R! i����i i�� s shared lockt win32g�������?g���� ��?i i ( i i ( R R# R R$ R' t FalseR6 R9 R R, R- R. R/ R0 R1 R t assertNotEqualR R R: t assertRaisest DBLockNotGrantedErrorR+ t platformt assertGreaterEqualR R2 R t versiont assertGreater( R R4 R, R t anID2R t start_timet end_timet min_dt( ( R< R s, /usr/lib64/python2.7/bsddb/test/test_lock.pyt test04_lock_timeout2` sB c C s d d l } | j d d k r1 t � j � } n t � j } | t j k rU d } n d } | j j � } t r� d | | f GHn xr t d � D]d } | j j | d | � } t r� d | | | f GHn | j j | � t r� d | | | f GHq� q� W| j j | � d S( Ni����i i t writet reads %s: locker ID: %si� s some locked things %s: Acquired %s lock: %ss %s: Released %s lock: %s( R, R- R t getNamet nameR R R R R t xrangeR R R ( R t lockTypeR, RN t ltR t iR ( ( s, /usr/lib64/python2.7/bsddb/test/test_lock.pyR* � s$ ( R t __module__R R R R5 RJ R* ( ( ( s, /usr/lib64/python2.7/bsddb/test/test_lock.pyR s - 5c C sH t j � } t r+ | j t j t � � n | j t j t d � � | S( Nt test01( t unittestt TestSuiteR t addTestt makeSuiteR ( t suite( ( s, /usr/lib64/python2.7/bsddb/test/test_lock.pyt test_suite� s t __main__t defaultTestRZ ( t __doc__R, R: RU t test_allR R R R R R t threadingR R- R R t TestCaseR RZ R t main( ( ( s, /usr/lib64/python2.7/bsddb/test/test_lock.pyt <module> s .�
[-] test_distributed_transactions.pyo
[open]
[-] test_basics.pyc
[open]
[-] test_dbshelve.pyc
[open]
[-] test_associate.pyo
[open]
[-] test_all.pyo
[open]
[-] test_thread.pyc
[open]
[+]
..
[-] test_replication.py
[open]
[-] test_fileid.pyo
[open]
[-] test_recno.py
[open]
[-] test_dbobj.py
[open]
[-] test_pickle.pyo
[open]
[-] test_fileid.pyc
[open]
[-] test_get_none.pyo
[open]
[-] test_thread.pyo
[open]
[-] test_sequence.pyo
[open]
[-] test_dbenv.pyc
[open]
[-] test_recno.pyo
[open]
[-] test_associate.py
[open]
[-] test_pickle.pyc
[open]
[-] test_dbenv.py
[open]
[-] test_distributed_transactions.pyc
[open]
[-] test_misc.py
[open]
[-] test_replication.pyo
[open]
[-] test_get_none.py
[open]
[-] test_sequence.py
[open]
[-] test_early_close.py
[open]
[-] test_misc.pyc
[open]
[-] test_early_close.pyo
[open]
[-] test_cursor_pget_bug.pyc
[open]
[-] test_dbobj.pyo
[open]
[-] test_recno.pyc
[open]
[-] test_compat.pyc
[open]
[-] test_lock.py
[open]
[-] test_compare.py
[open]
[-] test_all.pyc
[open]
[-] __init__.pyc
[open]
[-] test_associate.pyc
[open]
[-] test_db.py
[open]
[-] test_join.py
[open]
[-] test_db.pyc
[open]
[-] test_thread.py
[open]
[-] test_lock.pyo
[open]
[-] test_dbtables.pyo
[open]
[-] test_db.pyo
[open]
[-] test_dbenv.pyo
[open]
[-] test_basics.pyo
[open]
[-] test_dbobj.pyc
[open]
[-] test_early_close.pyc
[open]
[-] test_all.py
[open]
[-] test_join.pyo
[open]
[-] test_basics.py
[open]
[-] test_queue.py
[open]
[-] test_queue.pyc
[open]
[-] test_dbshelve.pyo
[open]
[-] test_cursor_pget_bug.pyo
[open]
[-] test_fileid.py
[open]
[-] test_dbtables.py
[open]
[-] test_sequence.pyc
[open]
[-] test_pickle.py
[open]
[-] test_get_none.pyc
[open]
[-] test_dbtables.pyc
[open]
[-] test_compat.pyo
[open]
[-] test_misc.pyo
[open]
[-] test_cursor_pget_bug.py
[open]
[-] __init__.py
[open]
[-] test_distributed_transactions.py
[open]
[-] test_join.pyc
[open]
[-] test_replication.pyc
[open]
[-] test_compare.pyc
[open]
[-] test_queue.pyo
[open]
[-] test_compat.py
[open]
[-] __init__.pyo
[open]
[-] test_lock.pyc
[open]
[-] test_compare.pyo
[open]
[-] test_dbshelve.py
[open]