← Back to branch summary

~pythonregexp2.7/python/issue2636-01

« back to all changes in this revision

Viewing changes to Lib/bsddb/test/test_replication.py

  • Committer: Jeffrey C. "The TimeHorse" Jacobs
  • Date: 2008-06-09 14:37:21 UTC
  • mfrom: (39022.1.14 Regexp-2.6)
  • Revision ID: darklord@timehorse.com-20080609143721-bj0g1mwta28038da
Merged in changes from the core Regexp branch.

Show diffs side-by-side

added added

removed removed

Lines of Context:
Lib/bsddb/test/test_replication.py
2
2
"""
3
3
 
4
4
import os
 
5
import time
5
6
import unittest
6
7
 
7
8
try:
57
58
        self.dbenvMaster.set_event_notify(confirmed_master)
58
59
        self.dbenvClient.set_event_notify(client_startupdone)
59
60
 
60
 
        self.dbenvMaster.repmgr_set_local_site("127.0.0.1",46117)
61
 
        self.dbenvClient.repmgr_set_local_site("127.0.0.1",46118)
62
 
        self.dbenvMaster.repmgr_add_remote_site("127.0.0.1",46118)
63
 
        self.dbenvClient.repmgr_add_remote_site("127.0.0.1",46117)
 
61
        master_port = test_support.find_unused_port()
 
62
        self.dbenvMaster.repmgr_set_local_site("127.0.0.1", master_port)
 
63
        client_port = test_support.find_unused_port()
 
64
        self.dbenvClient.repmgr_set_local_site("127.0.0.1", client_port)
 
65
        self.dbenvMaster.repmgr_add_remote_site("127.0.0.1", client_port)
 
66
        self.dbenvClient.repmgr_add_remote_site("127.0.0.1", master_port)
64
67
        self.dbenvMaster.rep_set_nsites(2)
65
68
        self.dbenvClient.rep_set_nsites(2)
66
69
        self.dbenvMaster.rep_set_priority(10)
91
94
        # The timeout is necessary in BDB 4.5, since DB_EVENT_REP_STARTUPDONE
92
95
        # is not generated if the master has no new transactions.
93
96
        # This is solved in BDB 4.6 (#15542).
94
 
        import time
95
97
        timeout = time.time()+2
96
98
        while (time.time()<timeout) and not (self.confirmed_master and self.client_startupdone) :
97
 
            time.sleep(0.001)
 
99
            time.sleep(0.02)
98
100
        if db.version() >= (4,6) :
99
101
            self.assertTrue(time.time()<timeout)
100
102
        else :
103
105
        d = self.dbenvMaster.repmgr_site_list()
104
106
        self.assertEquals(len(d), 1)
105
107
        self.assertEquals(d[0][0], "127.0.0.1")
106
 
        self.assertEquals(d[0][1], 46118)
 
108
        self.assertEquals(d[0][1], client_port)
107
109
        self.assertTrue((d[0][2]==db.DB_REPMGR_CONNECTED) or \
108
110
                (d[0][2]==db.DB_REPMGR_DISCONNECTED))
109
111
 
110
112
        d = self.dbenvClient.repmgr_site_list()
111
113
        self.assertEquals(len(d), 1)
112
114
        self.assertEquals(d[0][0], "127.0.0.1")
113
 
        self.assertEquals(d[0][1], 46117)
 
115
        self.assertEquals(d[0][1], master_port)
114
116
        self.assertTrue((d[0][2]==db.DB_REPMGR_CONNECTED) or \
115
117
                (d[0][2]==db.DB_REPMGR_DISCONNECTED))
116
118