ó
|
X\¬Qc @ sÉ d Z d d l Z d d l Z d d l Z d d l m Z m Z m Z m Z m Z m
|
Z
|
d e j 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 distributed transactions.
|
iÿÿÿÿN( t dbt test_supportt have_threadst verboset get_new_environment_patht get_new_database_patht DBReplicationc B s e Z d Z d Z RS( c s2 t _ t _ t j _ t j _ j j j t j t j Bt j
|
Bt j Bt j Bt j Bt j Bt j Bd j j j t j t j Bt j
|
Bt j Bt j Bt j Bt j Bt j Bd t _ _ f d } f d } j j | j j | d _ _ d S( Ni¶ c s | t j k r t _ n d S( N( R t DB_EVENT_REP_MASTERt Truet confirmed_master( t at bt c( t self( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR ! s c s | t j k r t _ n d S( N( R t DB_EVENT_REP_STARTUPDONER t client_startupdone( R
|
R R ( R ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR % s ( R t homeDirMastert homeDirClientR t DBEnvt dbenvMastert dbenvClientt opent DB_CREATEt DB_INIT_TXNt DB_INIT_LOGt DB_INIT_MPOOLt DB_INIT_LOCKt DB_INIT_REPt
|
DB_RECOVERt DB_THREADt FalseR R t set_event_notifyt Nonet dbMastert dbClient( R R R ( ( R sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyt setUp s >>c C s | j r | j j n | j r2 | j j n d } | j j | | j j | | j j | j j t j | j t j | j d S( Nc W s d S( N( ( t args( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyt dummy= s (
|
R" t closeR! R R R R t rmtreeR R ( R R% ( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyt tearDown4 s ( t __name__t
|
__module__R# R( ( ( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR s %t DBReplicationManagerc B s e Z d Z RS( c C s$ t j } t j } t j d k r#| j j d | | _ | j j t j t | j j t j
|
t | j j d | | _ | j j d | | _ | j j t j t | j j d | | _ | j j t j
|
t i t t t t g t j 6t t t t g t j 6t t t t g t j 6t t t t g t j
|
6t t t t g t j 6} x | j D]y \ } } xj t | j | j | j | j g | D]A \ } } | rÂ| j | j | q| j | j | qWqcW| j | j j | j j | j | j j | j j xc t | j | j | j | j g | | | | g D]. \ } } | j } | j | d | f qXWxH | j | j g D]4 } | j | j | j j | j j qWx· | j | j g D]4 } | j | j | j j | j j qèWnl | j j d | | j j d | | j j d | | j j d | | j j d | j j d | j j d | j j d | j j! t j" d | j j! t j" d | j | j j# t j" d | j | j j# t j" d | j j! t j$ d | j j! t j$ d | j | j j# t j$ d | j | j j# t j$ d | j j! t j% d
|
| j j! t j% d | j | j j# t j% d
|
| j | j j# t j% d | j j& t j' | j j& t j' | j j( d t j) | j j( d t j* | j | j j+ d | j | j j+ d | j | j j, d | j | j j, d | j | j j- t j' | j | j j- t j' d d l. } | j. d }
|
x6 | j. |
|
k r/| j/ o| j0 r/| j1 d qúW| j. |
|
k rdd d l2 } | j3 d IJt } n | j j4 } | j t5 | d | j6 d } | j | d d | j | d | | j | d t j7 k pê| d t j8 k | j j4 } | j t5 | d | j6 d } | j | d d | j | d | | j | d t j7 k pt| d t j8 k t j d k r¸| j j9 d t j: } | j d | k n t j; | j | _< | j j= } | j< j> d t j? t j@ d d | | jA d d l. } d d lB } | j. d }
|
xH | j. |
|
k r}| jC jD | jC jE | jF d r}| j1 d q6Wt j; | j | _G x t r. | j j= } y/ | jG j> d t j? d t jH d d d | WnC t jI k
|
r | jJ | jG jK t j; | j | _G qn X| jA PqW| j j= } | j< jL d d d | | jA d d l. } | j. d }
|
d } xo | j. |
|
k rô | d k rô | j j= } | jG jN d d | } | jA | d k r | j1 d q q W| j. |
|
k r
|
| r
|
| jO d n | j | j. |
|
k | j d | | j j= } | j< jP d d | | jA | j. d }
|
xo | j. |
|
k rö
|
| d k rö
|
| j j= } | jG jN d d | } | jA | d k r
|
| j1 d q
|
q
|
W| j | j. |
|
k | j d | d S( Ni i s 127.0.0.1i
|
i i iá i iP iù i¿ i iÿÿÿÿi< g{®Gáz?sB XXX: timeout happened beforestartup was confirmed - see issue 3892i i t flagst msgs_queuedt testi¶ t txng{®Gáz?t modet ABCt 123s> replication test skipped due to random failure, see issue 3892( i i ( i i (Q R t find_unused_portR t versionR t repmgr_sitet sitet
|
set_configt DB_GROUP_CREATORR t DB_LOCAL_SITEt site2R t site3t DB_BOOTSTRAP_HELPERt site4R t DB_LEGACYt DB_REPMGR_PEERt itemst zipt
|
assertTruet
|
get_configt assertFalset assertNotEqualt get_eidt get_addresst assertEqualt repmgr_site_by_eidt repmgr_set_local_sitet repmgr_add_remote_sitet rep_set_nsitest rep_set_priorityt rep_set_timeoutt DB_REP_CONNECTION_RETRYt rep_get_timeoutt DB_REP_ELECTION_TIMEOUTt DB_REP_ELECTION_RETRYt repmgr_set_ack_policyt DB_REPMGR_ACKS_ALLt repmgr_startt DB_REP_MASTERt DB_REP_CLIENTt rep_get_nsitest rep_get_priorityt repmgr_get_ack_policyt timeR R t sleept syst stderrt repmgr_site_listt lent valuest DB_REPMGR_CONNECTEDt DB_REPMGR_DISCONNECTEDt repmgr_statt DB_STAT_CLEARt DBR! t txn_beginR t DB_HASHR t committ os.patht patht existst joinR R" t DB_RDONLYt DBRepHandleDeadErrort abortR& t putR t gett skipTestt delete( R t master_portt client_portt dt it jt kt vt addrR[ t timeoutR] t startup_timeoutR/ t os( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyt test01_basic_replicationH s( 1 ""! #&
|
|
( %
|
%
|
|
|
!
|
|
!
|
( R) R* R ( ( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR+ G s t DBBaseReplicationc B s e Z d Z d Z d Z d Z e j d
|
k rH d Z n e j d k rf d Z n e j d k r d Z
|
n RS( c sã t j f d } f d } j j | j j | d d l } | j _ | j _ f d } f d } j j d | j j d j j d | j j d j
|
j j d j
|
j j d f d
|
} f d } d d l m } | d | } | d | }
|
d d l } | j d d k r| j t |
|
j t n t | _ t |
|
_ | _ |
|
_ d _ _ t g _ t g _ d S( Nc s. | t j k s | t j k r* t _ n d S( N( R R t DB_EVENT_REP_ELECTEDR R ( R
|
R R ( R ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR s c s | t j k r t _ n d S( N( R R R R ( R
|
R R ( R ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR s iÿÿÿÿc s j j | | f d S( N( t m2cRq ( t dbenvt controlt rect lsnpt envidR, ( R ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR s c s j j | | f d S( N( t c2mRq ( R R
R R R R, ( R ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR ! s i i
|
i i c s" j j j d j t S( Ni ( t thread_doR R t master_doing_electionR ( ( R ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyt thread_master1 s c s" j j j d j t S( Ni ( R R R t client_doing_electionR ( ( R ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyt thread_client5 s ( t Threadt target( R R# R R R t QueueR R t rep_set_transportRM RH RY t threadingR R] t version_infot setDaemonR t daemont t_mt t_cR R! R" R R R ( R R R R R R R R R R R R] ( ( R sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR# s@ c C sù | j r | j j n | j r2 | j j n | j j d | j j d | j j | j j d } | j
|
j | | j j | | j
|
j d | | j j d | | j j | j
|
j t j | j t j | j d S( Nc W s d S( N( ( R$ ( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR% Z s i i ( R" R& R! R Rq R R R Rm R R R R R R R' R R ( R R% ( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR( M s" c C s\ | j j d t j | j j d t j d } | | _ | j j | j j d S( NR, c S sH xA t rC | j } | d k r% d S| j | d | d | q Wd S( Ni i ( R Rr R t rep_process_message( t envt qR t election_statust must_be_masterR{ ( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR j s
|
(
|
R t rep_startR RV R RW R R t startR ( R R ( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyt basic_rep_threadingf s c C sç | j d d l } | j d } x6 | j | k r^ | j oJ | j r^ | j d q) W| j | j | k t j | j | _ | j j
|
} | j j d t j t j d d | | j d d l } d d l } | j d } xH | j | k r=| j j | j j | j d r=| j d qö Wt j | j | _ x t rî| j j
|
} y/ | j j d t j d t j d
|
d d | WnC t j k
|
rß| j | j j t j | j | _ qVn X| j PqVW| j j d t j } | j d | k | j j
|
} | j j d d d | | j d d l } | j d } d } xo | j | k rß| d k rß| j j
|
} | j j d d | } | j | d k rq| j d qqqqW| j | j | k | j d | | j j
|
} | j j! d d | | j | j d } xo | j | k r¹| d k r¹| j j
|
} | j j d d | } | j | d k rK| j d qKqKW| j | j | k | j d | d S( Niÿÿÿÿi< g{®Gáz?R. i¶ R/ i
|
g{®Gáz?R, R0 t master_changesR1 R2 (" R R[ R R R\ RB R Rf R R! Rg R Rh R Ri Rj Rk Rl Rm R R R" R Rn Ro Rp R& t rep_statRe Rq R Rr RH Rt ( R R[ R} R/ R Rw R{ ( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR u sr
|
|
%
|
%
|
|
|
!
|
|
!
|
i i c C se | j | j j \ } } | j j | d | d | j | j j | d | d f d S( Ni ( R R t rep_get_requestt rep_set_requestRH ( R t minimumt maximum( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyt test02_test_request¼ s
|
|
i c s j j d t j j j d t j f d } | _ j j j j j j t j
|
d j j t j
|
d t j d <xF t rß y% j j d d t j d <PWq t j k
|
rÛ q Xq W j j x j j d s qó Wd S( NR, c s# x t r | j } | d k r% d S j | d | d | } | rp j rp j j d t j t } n | d t j
|
k r f d } d r j rd d l m } t d <| d | } d d l }
|
|
|
j d d k r| j t n t | _ | j qq q Wd S( Ni i R, c sG x@ t rB y j d d t d <PWq t j k
|
r> q Xq Wd S( Ni i i ( R t rep_electR R t DBRepUnavailError( ( R R ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyt electÔ s
|
iÿÿÿÿ( R R i ( R Rr R R R R R R RV R t DB_REP_HOLDELECTIONR R R] R R R R ( R R R R R R{ t rRª R t tR] ( R ( R R sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR Ê s&
|
iPÃ i i i t startup_complete( R R R RW R R R R R RN RQ R R R¨ R R© RB R R¢ ( R R ( ( R sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyt test03_master_electionÄ s& c C sL d \ } } | j j | | | j | | f | j j | j d S( NiÒ iÎ ( iÒ iÎ ( R t rep_set_clockskewRH t rep_get_clockskewR ( R t fastt slow( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyt test04_test_clockskew s
|
( i i ( i i ( i i ( R) R* R# R( R R R R4 R§ R¯ R´ ( ( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyR
|
s B F <c C s t j } t j d k r t j } y | j t } Wn t } n X| j ~ | rz | j t j
|
t n t r | j t j
|
t q n | S( Ni i ( i i ( t unittestt TestSuiteR R4 R RZ R R R& t addTestt makeSuiteR+ R R ( t suiteR t ReplicationManager_available( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyt
|
test_suite
|
s
|
|
|
|
t __main__t defaultTestR» ( t __doc__R R[ Rµ t test_allR R R R R R t TestCaseR R+ R R» R) t main( ( ( sc /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/bsddb/test/test_replication.pyt <module> s .9Ãÿ
|
