File: //proc/3/task/3/cwd/usr/lib/python2.4/bsddb/test/test_lock.pyc
m๒
=5Dc @ s
d Z d k Z d k Z d k Z d k Z d k Z d k l Z y d k l Z l Z d Z
Wn e j
o
d Z
n Xd k Z d k
l Z y d k l Z Wn e j
o d k l Z n Xd e i f d YZ d
Z e d j o e i d d
n d S( s/
TestCases for testing the locking sub-system.
N( s pprint( s Threads
currentThreadi i ( s verbose( s dbt LockingTestCasec B s> t Z d Z d Z d Z d Z d Z d Z RS( Nc C s t i i t i i t i d d } | | _ y t i | Wn t i j
o n Xt
i | _ | i i
| t
i t
i Bt
i Bt
i B d S( Ni t db_home( t ost patht joint dirnamet syst argvt homeDirt selft mkdirt errort dbt DBEnvt envt opent DB_THREADt
DB_INIT_MPOOLt DB_INIT_LOCKt DB_CREATE( R R ( ( t* /usr/lib/python2.4/bsddb/test/test_lock.pyt setUp s ( c C sY | i i d k } | i t i i | i d } x | D] } t i
| q> Wd S( Nt *( R R t closet globR R R R t filest filet remove( R R R R ( ( R t tearDown* s
! c C sฎ t o d Gd d GHd | i i GHn | i i } t o
d | GHn | i i | d t i } t o
d | GHn t i d | i i
| t o
d | GHn d S(
Ns
s -=i s Running %s.test01_simple...s
locker ID: %ss some locked things Aquired lock: %si s Released lock: %s( t verboseR t __class__t __name__R t lock_idt anIDt lock_getR t
DB_LOCK_WRITEt lockt timet sleept lock_put( R R$ R! ( ( R t
test01_simple2 s
c C sฯ t o d Gd d GHd | i i GHn g } | i t d | i d d t i f | i t d | i d d t i
f | i t d | i d d t i
f | i t d | i d d t i f | i t d | i d d t i
f | i t d | i d d t i
f | i t d | i d d t i f | i t d | i d d t i f | i t d | i d d t i f x | D] } | i qWx | D] } | i
qทWd S( Ns
s -=i s Running %s.test02_threaded...t targett argsi i ( R R R R t threadst appendt Threadt theThreadR R# t DB_LOCK_READt tt startR ( R R+ R0 ( ( R t test02_threadedE s8
c C ss t | i d o\ | i i d t i | i i d t i | i i d t i | i i d t i n d S( Nt set_timeouti i@โ iหdx ( t hasattrR R R3 R t DB_SET_LOCK_TIMEOUTt DB_SET_TXN_TIMEOUT( R ( ( R t test03_set_timeoutc s
c C sห t i } | t i j o
d } n d } | i i } t o d | | f GHn | i i | d | } t o d | | | f GHn t i | | i i | t o d | | | f GHn d S( Nt writet reads %s: locker ID: %ss some locked things %s: Aquired %s lock: %ss %s: Released %s lock: %s( t
currentThreadt getNamet namet lockTypeR R# t ltR R R R! R R" R$ R% R& t sleepTimeR' ( R R? R= R< R! R$ R> ( ( R R. k s
( R t
__module__R R R( R2 R7 R. ( ( ( R R s
c C sJ t i } t o | i t i t n | i t i t d | S( Nt test01( t unittestt TestSuitet suitet have_threadst addTestt makeSuiteR ( RD ( ( R t
test_suite s
t __main__t defaultTestRH ( t __doc__R R t stringt tempfileR% t pprintt threadingR- R: RE t ImportErrorRB t test_allR t bsddb3R t bsddbt TestCaseR RH R t main( R RL R- RM RE RB RN R R R: RH R% R R ( ( R t ? s&
e