ó
|
X\¬Qc @ sì d 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 d d l 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\ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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\ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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 Aquired 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\ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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\ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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\ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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 j j | | j j j | j j | t j d k rî j j d k 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\ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_lock.pyR< f s R! iÿÿÿÿi i s shared lockgÒÞà ¹?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
|
assertTrueR R2 R t version( R R4 R, R t anID2R t
|
start_timet end_time( ( R< R s\ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_lock.pyt test04_lock_timeout2` s<
|
|
|
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: Aquired %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, RJ t ltR t iR ( ( s\ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_lock.pyR* s$ ( R t
|
__module__R R R R5 RF R* ( ( ( s\ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_lock.pyR s - .c 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\ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_lock.pyt
|
test_suite¬ s
|
t __main__t defaultTestRV ( t __doc__R: RQ t test_allR R R R R R t threadingR R, R- R R t TestCaseR RV R t main( ( ( s\ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_lock.pyt <module> s .
|
