Nexus File Manager
v2.0
🏠
Dashboard
⚡
System
🌐
›
usr
›
lib64
›
python2.7
›
bsddb
›
test
Quick:
⬆️ Parent
🌐 Root
🏠 Home
🌍 WWW
📁 Temp
⚙️ Etc
📤 Upload
📁 Create
⚡ WordPress Admin
🔄 Refresh
✏️ test_replication.pyc
← Back
� { fc @ 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( s3 /usr/lib64/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 ( s3 /usr/lib64/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 s3 /usr/lib64/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( ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyt dummy= s ( R" t closeR! R R R R t rmtreeR R ( R R% ( ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyt tearDown4 s ( t __name__t __module__R# R( ( ( ( s3 /usr/lib64/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 | � � q�WqcW| 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 � � q�Wx� | 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 | � | j7 | d t j8 t j9 f � | j j4 � } | j t5 | � d � | j6 � d } | j | d d � | j | d | � | j7 | d t j8 t j9 f � t j � d k r�| j j: d t j; � } | j7 d | � n t j< | j � | _= | j j> � } | j= j? d t j@ t jA d d | �| jB � d d l. } d d lC } | j. � d } xH | j. � | k r`| jD jE | jD jF | jG d � � r`| j1 d � qWt j< | j � | _H x� t r | j j> � } y/ | jH j? d t j@ d t jI d d d | �WnC t jJ k r | jK � | jH jL � t j< | j � | _H qyn X| jB � PqyW| j j> � } | j= jM d d d | �| jB � d d l. } | j. � d } d } xo | j. � | k r� | d k r� | j j> � } | jH jO d d | �} | jB � | d k ri | j1 d � qi qi W| j. � | k r | r | jP d � n | jQ | j. � | � | j d | � | j j> � } | j= jR d d | �| jB � | j. � d } xo | j. � | k r� | d k r� | j j> � } | jH jO d d | �} | jB � | d k rh | j1 d � qh qh W| jQ | j. � | � | 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 (S 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 assertInt 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 assertLesst delete( R t master_portt client_portt dt it jt kt vt addrR[ t timeoutR] t startup_timeoutR/ t os( ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyt test01_basic_replicationH s$ 1 ""! #& ( % % ! ! ( R) R* R� ( ( ( s3 /usr/lib64/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 ( s3 /usr/lib64/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 ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyR s i����c s � j j | | f � d S( N( t m2cRr ( t dbenvt controlt rect lsnpt envidR, ( R ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyR� s c s � j j | | f � d S( N( t c2mRr ( R� R� R� R� R� R, ( R ( s3 /usr/lib64/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 ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyt thread_master/ s c s" � j � j � j d � j t � S( Ni ( R� R R� t client_doing_electionR ( ( R ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyt thread_client3 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 s3 /usr/lib64/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$ ( ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyR% X s i i ( R" R& R! R� Rr R R� R� Rn R� R R R R� R R' R R ( R R% ( ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyR( K 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 Rs R t rep_process_message( t envt qR� t election_statust must_be_masterR} ( ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyR� h s ( R t rep_startR RV R RW R� R� t startR� ( R R� ( ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyt basic_rep_threadingd s c C s� | j � d d l } | j � d } x6 | j � | k r^ | j oJ | j r^ | j d � q) W| j | j � | � 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 � | _ qSn X| j � PqSW| j j d t j � } | j d | � | 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 rk| j d � qkqkW| j | j � | � | 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 rB| j d � qBqBW| j | j � | � | 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\ Ru R Rg R R! Rh R Ri R Rj Rk Rl Rm Rn R R R" R Ro Rp Rq R& t rep_statRf Rb Rr R Rs RH Rv ( R R[ R R/ R� Ry R} ( ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyR� s 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( ( s3 /usr/lib64/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� ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyt elect� s i����( R� R� i ( R Rs 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� s3 /usr/lib64/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 s3 /usr/lib64/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( ( s3 /usr/lib64/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� ( ( ( s3 /usr/lib64/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( ( s3 /usr/lib64/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( ( ( s3 /usr/lib64/python2.7/bsddb/test/test_replication.pyt <module> s .9��
💻
System Info
Current path
/usr/lib64/python2.7/bsddb/test
Contents
0 folders, 75 files
Disk free
100.60 GB
PHP version
8.3.30
🚀
Quick Actions
📍 Script location
🌐 Web root
🗑️ Temp
📁 /usr/lib64/python2.7/bsddb/test
⚡ Nexus File Manager • 75 items