File: //usr/lib/python2.4/bsddb/test/test_thread.pyc
mò
‚=5Dc @ sT d Z d k Z d k Z d k Z d k Z d k Z d k Z d k l Z d k l Z y e e
f Wn e j
o d Z d Z
n Xd Z y d k
l Z l Z e Z Wn e j
o
e
Z n Xd k Z d k l Z y d k l Z l Z Wn& e j
o d k l Z l Z n Xd
e i f d „ ƒ YZ d e f d
„ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ! d e! f d „ ƒ YZ" d e! f d „ ƒ YZ# d e! f d „ ƒ YZ$ d e! f d! „ ƒ YZ% d" „ Z& e' d# j o e i( d$ d% ƒ n d S(& s- TestCases for multi-threaded access to a DB.
N( s pprint( s randomi i t -( s Threads
currentThread( s verbose( s dbs dbutilst BaseThreadedTestCasec B sG t Z e i Z d Z d Z d Z d „ Z d „ Z d „ Z
d „ Z RS( Ni c C s4 t o t i t _ n t i i t i i t i d ƒ d ƒ } | | _
y t i | ƒ Wn/ t
j
o# } | i t i j o ‚ q‹ n Xt i ƒ | _ | i ƒ | i i | | i t i Bƒ | i i d | _ t i | i ƒ | _ | i o | i i | i ƒ n | i i | i | i | i t i Bƒ d S( Ni t db_homes .db(! t verboset syst stdoutt dbutilst _deadlock_VerboseFilet ost patht joint dirnamet argvt homeDirt selft mkdirt OSErrort et errnot EEXISTt dbt DBEnvt envt
setEnvOptst opent envflagst DB_CREATEt __class__t __name__t filenamet DBt dt
dbsetflagst set_flagst dbtypet dbopenflags( R R R
( ( t, /usr/lib/python2.4/bsddb/test/test_thread.pyt setUp. s" (
c C s. | i i ƒ | i i ƒ t i | i ƒ d S( N( R R t closeR t shutilt rmtreeR
( R ( ( R$ t tearDownB s
c C s d S( N( ( R ( ( R$ R G s c C s t i | g d ƒ S( Ni ( t DASHR
t key( R R+ ( ( R$ t makeDataJ s ( R t
__module__R t
DB_UNKNOWNR" R# R R R% R) R R, ( ( ( R$ R ( s t ConcurrentDataStoreBasec B sU t Z e i Z e i e i Be i BZ d Z d Z d Z
d „ Z d „ Z d „ Z
RS( Ni iè c C s t o d Gd d GHd | i i GHn g } xU t | i ƒ D]D } t d | i d | i
| i | f d d | ƒ } | i
| ƒ q= WxO t | i ƒ D]> } t d | i d | i
| f d d | ƒ } | i
| ƒ q• Wx | D] } | i ƒ qÞ Wx | D] } | i ƒ qù Wd S(
Ns
s -=i s( Running %s.test01_1WriterMultiReaders...t targett argst names writer %ds reader %d( R R R R t threadst ranget writerst xt Threadt writerThreadR t recordst wtt appendt readerst readerThreadt rtt tt startR
( R R> R: R3 R? R6 ( ( R$ t test01_1WriterMultiReadersX s,
c C së t ƒ i ƒ } | | } | | d d } t o d | | | f GHn xt t | | ƒ D]c } d | } t i | i | | i | ƒ d d ƒt o' | d d j o d | | | f GHqX qX Wt o
d | GHn t o
d
| GHn d S( Ni s %s: creating records %d - %ds %04dt max_retriesi id i s %s: records %d - %d finisheds %s: finished creating recordss %s: thread finished( t
currentThreadt getNameR2 t howManyt writerNumR@ t stopR R4 R6 R+ R t DeadlockWrapR t putR R, ( R R RE RF RG R@ R+ R6 R2 ( ( R$ R8 r s
c
C sè t i d | ƒ t ƒ i ƒ } x t d ƒ D]Ÿ } | i ƒ } d } | i ƒ } xG | o? | d 7} | \ } } | i | i | ƒ | ƒ | i ƒ } qT Wt o d | | f GHn | i ƒ t i d ƒ q- Wt o
d | GHn d S( Nf0.01i i i s %s: found %d recordsf0.050000000000000003s %s: thread finished( t timet sleept readerNumRC RD R2 R4 t loopR t cursort ct countt firstt recR+ t dataR t assertEqualR, t nextR R& (
R R RL RP RO R+ RR RS RM R2 ( ( R$ R= ’ s&
( R R- R t DB_THREADR# t DB_INIT_CDBt
DB_INIT_MPOOLR R< R5 R9 RA R8 R= ( ( ( R$ R/ Q s t BTreeConcurrentDataStorec B s# t Z e i Z d Z d Z d Z RS( Ni i
iè ( R R- R t DB_BTREER" R5 R< R9 ( ( ( R$ RY ¨ s t HashConcurrentDataStorec B s# t Z e i Z d Z d Z d Z RS( Ni i
iè ( R R- R t DB_HASHR" R5 R< R9 ( ( ( R$ R[ ¯ s t SimpleThreadedBasec B s^ t Z e i Z e i e i Be i BZ d Z d Z d Z
d „ Z d „ Z d „ Z
d „ Z RS( Ni i iè c C s | i i t i ƒ d S( N( R R t
set_lk_detectR t DB_LOCK_DEFAULT( R ( ( R$ R ¿ s c C s t o d Gd d GHd | i i GHn g } xU t | i ƒ D]D } t d | i d | i
| i | f d d | ƒ } | i
| ƒ q= WxO t | i ƒ D]> } t d | i d | i
| f d d | ƒ } | i
| ƒ q• Wx | D] } | i ƒ qÞ Wx | D] } | i ƒ qù Wd S(
Ns
s -=i s Running %s.test02_SimpleLocks...R0 R1 R2 s writer %ds reader %d( R R R R R3 R4 R5 R6 R7 R8 R R9 R: R; R< R= R> R? R@ R
( R R> R: R3 R? R6 ( ( R$ t test02_SimpleLocks s,
c C sU t ƒ i ƒ } | | } | | d d } t o d | | | f GHn xà t | | ƒ D]Ï } d | } t i | i | | i | ƒ d d ƒt o' | d d j o d | | | f GHn t ƒ d j o\ xY t | | ƒ D]D } d | } t i | i | d d ƒ}
| i |
| i | ƒ ƒ qÛ WqX qX Wy t i | i d d ƒWn( t i j
o } t o d
GHqpn XxÊ t | | ƒ D]¹ } d | } t i | i | d d ƒ}
t o' | d d j o d | | |
f GHn | i |
| i | ƒ ƒ t ƒ d j o7 t i | i | d d ƒt o d
| | f GHq9q€q€Wt o
d | GHn d S( Ni s %s: creating records %d - %ds %04dRB i id i s %s: records %d - %d finishedf0.050000000000000003s could not complete sync()...s %s: fetched record (%s, %s)f0.10000000000000001s %s: deleted record %ss %s: thread finished( RC RD R2 RE RF R@ RG R t xrangeR6 R+ R RH R RI R R, t randomt yt getRS RT t syncR t DBIncompleteErrort valt delete( R R RE RF RG R@ Rg R+ R6 Rc RS R2 ( ( R$ R8 Ú sH
%
c
C s t i d | ƒ t ƒ i ƒ } xÅ t d ƒ D]· } | i ƒ } d } t i
| i d d ƒ} xS | oK | d 7} | \ } } | i | i | ƒ | ƒ t i
| i d d ƒ} q` Wt o d | | f GHn | i ƒ t i d ƒ q- Wt o
d | GHn d S(
Nf0.01i i RB i
i s %s: found %d recordsf0.050000000000000003s %s: thread finished( RJ RK RL RC RD R2 R4 RM R RN RO RP R RH RQ RR R+ RS R RT R, RU R R& (
R R RL RP RO R+ RR RS RM R2 ( ( R$ R= s&
( R R- R RV R# RX t DB_INIT_LOCKR R< R5 R9 R R` R8 R= ( ( ( R$ R] ¸ s -t BTreeSimpleThreadedc B s t Z e i Z RS( N( R R- R RZ R" ( ( ( R$ Rj s t HashSimpleThreadedc B s t Z e i Z RS( N( R R- R R\ R" ( ( ( R$ Rk ! s t ThreadedTransactionsBasec B s‹ t Z e i e i BZ e i e i Be i Be i Be i BZ
d Z d Z d Z
d Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( Ni iÐ c C s d S( N( ( R ( ( R$ R 5 s c C s@ t o d Gd d GHd | i i GHn g } xU t | i ƒ D]D } t d | i d | i
| i | f d d | ƒ } | i
| ƒ q= WxO t | i ƒ D]> } t d | i d | i
| f d d | ƒ } | i
| ƒ q• Wt d | i ƒ } | i ƒ x | D] } | i ƒ qú Wx | D] } | i ƒ qWt | _ | i ƒ d S(
Ns
s -=i s) Running %s.test03_ThreadedTransactions...R0 R1 R2 s writer %ds reader %d( R R R R R3 R4 R5 R6 R7 R8 R R9 R: R; R< R= R> t deadlockThreadt dtR@ R? R
t Falset doLockDetect( R R> R: R3 R? R6 Rn ( ( R$ t test03_ThreadedTransactions9 s4
c
C s t } xÿ | p÷ yš | i i d | i ƒ } xk t | | ƒ D]Z } d | } | i | | i | ƒ | ƒ t o' | d d j o d | | | f GHq; q; W| i ƒ t } Wq t i t i f j
o> } t o d | | d f GHn | i ƒ t i d ƒ q Xq Wd S( Ns %04did i s %s: records %d - %d finisheds %s: Aborting transaction (%s)i f0.050000000000000003( Ro t finishedR R t txn_begint Nonet txnFlagt txnR4 R@ RG R6 R+ R RI R, R R2 t committ TrueR t DBLockDeadlockErrort DBLockNotGrantedErrorRg t abortRJ RK (
R R R2 R@ RG Rv Rg Rr R+ R6 ( ( R$ t doWriteY s$
c C s t ƒ i ƒ } | | } | | d d } t o d | | | f GHn d } x= t | | | ƒ D]) } | i | | | t | | | ƒ ƒ qa Wt o
d | GHn t o
d | GHn t }
x2|
p*yÍ g }
| i i d | i ƒ } x~ t d ƒ D]p } t t ƒ | ƒ | } d | } | i | d | t i ƒ } | d j o! | i | | ƒ |
i | ƒ qô qô W| i ƒ t! }
t o d | |
f GHn Wq¿ t i" t i# f j
o> } t o d | | d f GHn | i% ƒ t& i' d
ƒ q¿ Xq¿ Wt o
d | GHn d S( Ni s %s: creating records %d - %did s %s: finished creating recordss %s: deleting a few recordsi
s %04ds %s: deleted records %ss %s: Aborting transaction (%s)f0.050000000000000003s %s: thread finished(( RC RD R2 RE RF R@ RG R t stepR4 R6 R R| R t minRo Rr t recsR Rs Rt Ru Rv t intRb R+ Rd R t DB_RMWRS Rh R; Rw Rx Ry Rz Rg R{ RJ RK ( R R RE RF Rv Rg R@ RG R} R+ R RS R2 Rr R6 ( ( R$ R8 k sL
'
c
C s“ t i d | d ƒ t ƒ i ƒ } xTt d ƒ D]F} t } x*| p"y» | i i d | i ƒ } | i | ƒ } d } | i ƒ } xG | o? | d 7} | \ } }
| i | i | ƒ |
ƒ | i ƒ } q† Wt o d | | f GHn | i ƒ | i ƒ t } Wq@ t i t i! f j
oH } t o d | | d f GHn | i ƒ | i# ƒ t i d ƒ q@ Xq@ Wt i d ƒ q1 Wt o
d | GHn d S( Nf0.01f0.050000000000000003i i i s %s: found %d recordss %s: Aborting transaction (%s)s %s: thread finished($ RJ RK RL RC RD R2 R4 RM Ro Rr R R Rs Rt Ru Rv R RN RO RP RQ RR R+ RS RT R, RU R R& Rw Rx R Ry Rz Rg R{ (
R R RL RP Rv RO Rg Rr R+ RR RS RM R2 ( ( R$ R= ” s@
c C s t | _ xo | i od t i d ƒ y: | i i t i t i ƒ } t o | o
d | GHn Wq t i j
o q Xq Wd S( Nf0.5s. deadlock: Aborted %d deadlocked transaction(s)(
Rx R Rp RJ RK R t lock_detectR t DB_LOCK_RANDOMt DB_LOCK_CONFLICTt abortedR t DBError( R R… ( ( R$ Rm µ s
( R R- R RV t DB_AUTO_COMMITR# RX Ri t DB_INIT_LOGt DB_INIT_TXNR R< R5 R9 Ru R Rq R| R8 R= Rm ( ( ( R$ Rl ( s % ) !t BTreeThreadedTransactionsc B s# t Z e i Z d Z d Z d Z RS( Ni i iÐ ( R R- R RZ R" R5 R< R9 ( ( ( R$ RŠ Ã s t HashThreadedTransactionsc B s# t Z e i Z d Z d Z d Z RS( Ni i iÐ ( R R- R R\ R" R5 R< R9 ( ( ( R$ R‹ É s t BTreeThreadedNoWaitTransactionsc B s, t Z e i Z d Z d Z d Z e i Z RS( Ni i iÐ (
R R- R RZ R" R5 R< R9 t
DB_TXN_NOWAITRu ( ( ( R$ RŒ Ï s
t HashThreadedNoWaitTransactionsc B s, t Z e i Z d Z d Z d Z e i Z RS( Ni i iÐ (
R R- R R\ R" R5 R< R9 R Ru ( ( ( R$ RŽ Ö s
c C sÐ t i ƒ } t o´ | i t i t ƒ ƒ | i t i t ƒ ƒ | i t i t ƒ ƒ | i t i t ƒ ƒ | i t i t
ƒ ƒ | i t i t ƒ ƒ | i t i t ƒ ƒ | i t i t
ƒ ƒ n d GH| S( Ns- Threads not available, skipping thread tests.( t unittestt TestSuitet suitet have_threadst addTestt makeSuiteRY R[ Rj Rk RŠ R‹ RŒ RŽ ( R‘ ( ( R$ t
test_suiteà s t __main__t defaultTestR• () t __doc__R R RJ R R' t tempfilet pprintRb Rx Ro t NameErrorR* t threadingR7 RC R’ t ImportErrorR t test_allR t bsddb3R R t bsddbt TestCaseR R/ RY R[ R] Rj Rk Rl RŠ R‹ RŒ RŽ R• R t main( RŽ R RC R Rb R' R‹ R™ R R/ Rš R• Rx RŒ RŠ R7 Rj R R R] R’ R* Ro Rk R[ Rl R RJ RY R R ( ( R$ t ? sP
)W e›