PATH:
usr
/
lib64
/
python2.7
/
bsddb
/
test
� ��^c @ sD d Z d d l Z d d l Z d d l Z d d l Z d d l m Z d Z y e Wn' e k r} d e f d � � YZ n Xd d l Z d d l m Z 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 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& k r@e j' d' d( � n d S() s- TestCases for multi-threaded access to a DB. i����N( t randomt -t WindowsErrorc B s e Z RS( ( t __name__t __module__( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR s ( t dbt dbutilst test_supportt verboset have_threadst get_new_environment_patht get_new_database_path( t Threadi i ( t currentThread( t current_threadt BaseThreadedTestCasec B sG e Z e j Z d Z d Z d Z d � Z d � Z d � Z d � Z RS( i c C s� t r t j t _ n t � | _ t j � | _ | j � | j j | j | j t j B� | j j d | _ t j | j � | _ | j r� | j j | j � n | j j | j | j | j t j B� d S( Ns .db( R t syst stdoutR t _deadlock_VerboseFileR t homeDirR t DBEnvt envt setEnvOptst opent envflagst DB_CREATEt __class__R t filenamet DBt dt dbsetflagst set_flagst dbtypet dbopenflags( t self( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyt setUp& s c C s. | j j � | j j � t j | j � d S( N( R t closeR R t rmtreeR ( R" ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyt tearDown5 s c C s d S( N( ( R" ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR : s c C s t j | g d � S( Ni ( t DASHt join( R" t key( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyt makeData= s ( R R R t DB_UNKNOWNR R! R R R# R& R R* ( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR s t ConcurrentDataStoreBasec B sU e Z e j Z e j e j Be j BZ d Z d Z d Z d � Z d � Z d � Z RS( i i� c C sQ t r% d Gd d GHd | j j GHn t | j � } d d l } | j | � | j | j } | j | j } | j | j | j | � | j | j | j | � | j | | d � g } x{ t | j � D]j } t d | j d | j | f d d | � } t j d d k r | j t � n t | _ | j | � q� Wg } x� t | j � D]} } | | | | | d !} | j � | | | | | d !} t d | j d | j | | f d d | � } | j | � qOWxD | D]< } t j d d k r | j t � n t | _ | j � q�Wx | D] } | j � q Wx | D] } | j � q9Wd S( Ns s -=i s( Running %s.test01_1WriterMultiReaders...i����i t targett argst names reader %di i s writer %d( R R R t ranget recordsR t shufflet writerst readerst assertEqualt xrangeR t readerThreadR R t version_infot setDaemont Truet daemont appendt sortt writerThreadt startR( ( R" t keysR t records_per_writert readers_per_writerR4 t xt rtR3 t at bt wtt t( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyt test01_1WriterMultiReadersK sN c C s$ t j d d k r% t � j � } n t � j } t rL d | t t f GHn t | � t | � } | } x� | D]� } d | } t j | j | | j | � d d �t r� | d d k r� d | t | f GHn | d 8} | so | j � j � | } qo qo Wt rd | GHn t r d | GHn d S( Ni i s %s: creating records %d - %ds %04dt max_retriesi id s %s: records %d - %d finishedi s %s: finished creating recordss %s: thread finished( R R8 R t getNameR/ R R? t stopt lenR t DeadlockWrapt putR* t pop( R" R R@ R4 R/ t countt count2RC R) ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR> } s* c C s� t j d d k r% t � j � } n t � j } x� t d � D]� } | j � } d } | j � } xE | r� | d 7} | \ } } | j | j | � | � | j � } qe Wt r� d | | f GHn | j � q> Wt r� d | GHn d S( Ni i i i s %s: found %d recordss %s: thread finished( R R8 R RK R/ R6 t cursort firstR5 R* t nextR R$ ( R" R t readerNumR/ t it cRQ t recR) t data( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR7 � s" ( R R R t DB_THREADR! t DB_INIT_CDBt DB_INIT_MPOOLR R4 R3 R1 RI R> R7 ( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR, D s 2 t BTreeConcurrentDataStorec B s# e Z e j Z d Z d Z d Z RS( i i i� ( R R R t DB_BTREER R3 R4 R1 ( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR^ � s t HashConcurrentDataStorec B s# e Z e j Z d Z d Z d Z RS( i i i� ( R R R t DB_HASHR R3 R4 R1 ( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR` � s t SimpleThreadedBasec B s^ e Z e j Z e j e j Be j BZ d Z d Z d Z d � Z d � Z d � Z d � Z RS( i i i� c C s | j j t j � d S( N( R t set_lk_detectR t DB_LOCK_DEFAULT( R" ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR � s c C sQ t r% d Gd d GHd | j j GHn t | j � } d d l } | j | � | j | j } | j | j } | j | j | j | � | j | j | j | � | j | | d � g } x{ t | j � D]j } t d | j d | j | f d d | � } t j d d k r | j t � n t | _ | j | � q� Wg } x� t | j � D]} } | | | | | d !} | j � | | | | | d !} t d | j d | j | | f d d | � } | j | � qOWxD | D]< } t j d d k r | j t � n t | _ | j � q�Wx | D] } | j � q Wx | D] } | j � q9Wd S( Ns s -=i s Running %s.test02_SimpleLocks...i����i R- R. R/ s reader %di i s writer %d( R R R R0 R1 R R2 R3 R4 R5 R6 R R7 R R R8 R9 R: R; R< R= R> R? R( ( R" R@ R RA RB R4 RC RD R3 RE RF RG RH ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyt test02_SimpleLocks� sL c C s t j d d k r% t � j � } n t � j } t rL d | t t f GHn t | � t | � } | } x� | D]� } d | } t j | j | | j | � d d �t r� | d d k r� d | t | f GHn | d 8} | so | j � j � | } qo qo Wt rd | GHn d S( Ni i s %s: creating records %d - %ds %04dRJ i id s %s: records %d - %d finishedi s %s: thread finished( R R8 R RK R/ R R? RL RM R RN RO R* RP ( R" R R@ R4 R/ RQ RR RC R) ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR> � s& c C s� t j d d k r% t � j � } n t � j } | j � } d } t j | j d d �} xQ | r� | d 7} | \ } } | j | j | � | � t j | j d d �} q^ Wt r� d | | f GHn | j � t r� d | GHn d S( Ni i RJ i i s %s: found %d recordss %s: thread finished( R R8 R RK R/ RS R RN RT R5 R* RU R R$ ( R" R RV R/ RX RQ RY R) RZ ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR7 s ( R R R R[ R! R] t DB_INIT_LOCKR R4 R3 R1 R Re R> R7 ( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyRb � s 2 t BTreeSimpleThreadedc B s e Z e j Z RS( ( R R R R_ R ( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyRg - s t HashSimpleThreadedc B s e Z e j Z RS( ( R R R Ra R ( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyRh 1 s t ThreadedTransactionsBasec B s� e Z e j e j BZ e j e j Be j Be j Be j BZ d Z d Z d Z d Z d � Z d � Z d � Z d � Z d � Z RS( i i� c C s d S( N( ( R" ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR E s c C s� t r% d Gd d GHd | j j GHn t | j � } d d l } | j | � | j | j } | j | j } | j | j | j | � | j | j | j | � | j | | d � g } x{ t | j � D]j } t d | j d | j | f d d | � } t j d d k r | j t � n t | _ | j | � q� Wg } x� t | j � D]s } | | | | | d !} | | | | | d !} t d | j d | j | | f d d | � } | j | � qOWt d | j � } t j d d k r�| j t � n t | _ | j � xD | D]< } t j d d k r>| j t � n t | _ | j � qWx | D] } | j � q\Wx | D] } | j � qwWt | _ | j � d S( Ns s -=i s) Running %s.test03_ThreadedTransactions...i����i R- R. R/ s reader %di i s writer %d( R R R R0 R1 R R2 R3 R4 R5 R6 R R7 R R R8 R9 R: R; R< R> t deadlockThreadR? R( t Falset doLockDetect( R" R@ R RA RB R4 RC RD R3 RE RF RG t dtRH ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyt test03_ThreadedTransactionsI sZ c C s� t j d d k r% t � j � } n t � j } t | � t | � } x,t | � ruy� | j j d | j � } | | } x_ | D]W } d | } | j | | j | � | � t r� | d d k r� d | t | f GHq� q� W| j � | | } | j � j � WqJ t j t j f k rq} t rdt j d k rKd | | d f GHqdd | | j d f GHn | j � qJ XqJ Wt r�d | GHn d S( Ni i s %04did s %s: records %d - %d finishedi i s %s: Aborting transaction (%s)i s %s: thread finished( i i ( R R8 R RK R/ RM R t txn_begint Nonet txnFlagRO R* R R? t commitRP R t DBLockDeadlockErrort DBLockNotGrantedErrorR. t abort( R" R R@ R4 R/ RQ t txnt keys2RC R) t val( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR> � s2 c C s� t j d d k r% t � j � } n t � j } t } x;| sty� | j j d | j � } | j | � } d } | j � } xE | r� | d 7} | \ } } | j | j | � | � | j � } q Wt r� d | | f GHn | j � | j � t } Wq: t j t j f k rp} t rYt j d k r@d | | d f GHqYd | | j d f GHn | j � | j � q: Xq: Wt r�d | GHn d S( Ni i i s %s: found %d recordsi i s %s: Aborting transaction (%s)s %s: thread finished( i i ( R R8 R RK R/ Rk R Ro Rp Rq RS RT R5 R* RU R R$ Rr R: R Rs Rt R. Ru ( R" R RV R/ t finishedRv RX RQ RY R) RZ Rx ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR7 � s< c C sx t | _ xh | j rs t j d � y7 | j j t j t j � } t rX | rX d | GHn Wq t j k ro q Xq Wd S( Ng�������?s. deadlock: Aborted %d deadlocked transaction(s)( R: Rl t timet sleepR t lock_detectR t DB_LOCK_RANDOMt DB_LOCK_CONFLICTR t DBError( R" t aborted( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyRj � s ( R R R R[ t DB_AUTO_COMMITR! R] Rf t DB_INIT_LOGt DB_INIT_TXNR R4 R3 R1 Rq R Rn R> R7 Rj ( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyRi 8 s ; #t BTreeThreadedTransactionsc B s# e Z e j Z d Z d Z d Z RS( i i i� ( R R R R_ R R3 R4 R1 ( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR� � s t HashThreadedTransactionsc B s# e Z e j Z d Z d Z d Z RS( i i i� ( R R R Ra R R3 R4 R1 ( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR� � s t BTreeThreadedNoWaitTransactionsc B s, e Z e j Z d Z d Z d Z e j Z RS( i i i� ( R R R R_ R R3 R4 R1 t DB_TXN_NOWAITRq ( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR� � s t HashThreadedNoWaitTransactionsc B s, e Z e j Z d Z d Z d Z e j Z RS( i i i� ( R R R Ra R R3 R4 R1 R� Rq ( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyR� � s c C s� t j � } t r� | j t j t � � | j t j t � � | j t j t � � | j t j t � � | j t j t � � | j t j t � � | j t j t � � | j t j t � � n d GH| S( Ns- Threads not available, skipping thread tests.( t unittestt TestSuiteR t addTestt makeSuiteR^ R` Rg Rh R� R� R� R� ( t suite( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyt test_suite� s t __main__t defaultTestR� (( t __doc__t osR Rz t errnoR R' R t NameErrort ExceptionR� t test_allR R R R R R R t threadingR R8 R R t TestCaseR R, R^ R` Rb Rg Rh Ri R� R� R� R� R� R t main( ( ( s. /usr/lib64/python2.7/bsddb/test/test_thread.pyt <module> s@ 4$m l�
[-] 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]