File manager - Edit - /opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyc
Back
� ��Wc @ 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__( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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" ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyt tearDown5 s c C s d S( N( ( R" ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyR : s c C s t j | g d � S( Ni ( t DASHt join( R" t key( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyt makeData= s ( R R R t DB_UNKNOWNR R! R R R# R& R R* ( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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 sT 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 k � 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 | � qRWxD | D]< } t j d d k r| j t � n t | _ | j � q�Wx | D] } | j � q!Wx | D] } | j � q<Wd 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 assertTruet 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( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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 R9 R t getNameR/ R R@ t stopt lenR t DeadlockWrapt putR* t pop( R" R RA R4 R/ t countt count2RD R) ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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 R9 R RL R/ R7 t cursort firstR5 R* t nextR R$ ( R" R t readerNumR/ t it cRR t recR) t data( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyR8 � s" ( R R R t DB_THREADR! t DB_INIT_CDBt DB_INIT_MPOOLR R4 R3 R1 RJ R? R8 ( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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 ( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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 ( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyRa � 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" ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyR � s c C sT 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 k � 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 | � qRWxD | D]< } t j d d k r| j t � n t | _ | j � q�Wx | D] } | j � q!Wx | D] } | j � q<Wd 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 R7 R R8 R R R9 R: R; R< R= R> R? R@ R( ( R" RA R RB RC R4 RD RE R3 RF RG RH RI ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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 %04dRK i id s %s: records %d - %d finishedi s %s: thread finished( R R9 R RL R/ R R@ RM RN R RO RP R* RQ ( R" R RA R4 R/ RR RS RD R) ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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 RK i i s %s: found %d recordss %s: thread finished( R R9 R RL R/ RT R RO RU R5 R* RV R R$ ( R" R RW R/ RY RR RZ R) R[ ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyR8 s ( R R R R\ R! R^ t DB_INIT_LOCKR R4 R3 R1 R Rf R? R8 ( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyRc � s 2 t BTreeSimpleThreadedc B s e Z e j Z RS( ( R R R R` R ( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyRh - s t HashSimpleThreadedc B s e Z e j Z RS( ( R R R Rb R ( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyRi 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" ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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 k � 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 | � qRWt d | j � } t j d d k r�| j t � n t | _ | j � xD | D]< } t j d d k rA| j t � n t | _ | j � qWx | D] } | j � q_Wx | D] } | j � qzWt | _ | 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 R7 R R8 R R R9 R: R; R< R= R? t deadlockThreadR@ R( t Falset doLockDetect( R" RA R RB RC R4 RD RE R3 RF RG RH t dtRI ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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 R9 R RL R/ RN R t txn_begint Nonet txnFlagRP R* R R@ t commitRQ R t DBLockDeadlockErrort DBLockNotGrantedErrorR. t abort( R" R RA R4 R/ RR t txnt keys2RD R) t val( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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 R9 R RL R/ Rl R Rp Rq Rr RT RU R5 R* RV R R$ Rs R; R Rt Ru R. Rv ( R" R RW R/ t finishedRw RY RR RZ R) R[ Ry ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyR8 � 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; Rm t timet sleepR t lock_detectR t DB_LOCK_RANDOMt DB_LOCK_CONFLICTR t DBError( R" t aborted( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyRk � s ( R R R R\ t DB_AUTO_COMMITR! R^ Rg t DB_INIT_LOGt DB_INIT_TXNR R4 R3 R1 Rr R Ro R? R8 Rk ( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyRj 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 ( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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 Rb R R3 R4 R1 ( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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_NOWAITRr ( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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 Rb R R3 R4 R1 R� Rr ( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/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_ Ra Rh Ri R� R� R� R� ( t suite( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyt test_suite� s t __main__t defaultTestR� (( t __doc__t osR R{ t errnoR R' R t NameErrort ExceptionR� t test_allR R R R R R R t threadingR R9 R R t TestCaseR R, R_ Ra Rc Rh Ri Rj R� R� R� R� R� R t main( ( ( so /builddir/build/BUILDROOT/imh-python-2.7.12-1.el7.x86_64/opt/imh-python/lib/python2.7/bsddb/test/test_thread.pyt <module> s@ 4$m l�
| ver. 1.4 |
Github
|
.
| PHP 8.3.31 | Generation time: 0 |
proxy
|
phpinfo
|
Settings