Lines Matching refs:db
8 from test_all import db, test_support, have_threads, verbose, \
19 self.dbenvMaster = db.DBEnv()
20 self.dbenvClient = db.DBEnv()
25 self.dbenvMaster.open(self.homeDirMaster, db.DB_CREATE | db.DB_INIT_TXN
26 | db.DB_INIT_LOG | db.DB_INIT_MPOOL | db.DB_INIT_LOCK |
27 db.DB_INIT_REP | db.DB_RECOVER | db.DB_THREAD, 0666)
28 self.dbenvClient.open(self.homeDirClient, db.DB_CREATE | db.DB_INIT_TXN
29 | db.DB_INIT_LOG | db.DB_INIT_MPOOL | db.DB_INIT_LOCK |
30 db.DB_INIT_REP | db.DB_RECOVER | db.DB_THREAD, 0666)
34 if b==db.DB_EVENT_REP_MASTER :
38 if b==db.DB_EVENT_REP_STARTUPDONE :
75 if db.version() >= (5, 2) :
77 self.site.set_config(db.DB_GROUP_CREATOR, True)
78 self.site.set_config(db.DB_LOCAL_SITE, True)
82 self.site3.set_config(db.DB_BOOTSTRAP_HELPER, True)
84 self.site4.set_config(db.DB_LOCAL_SITE, True)
87 db.DB_BOOTSTRAP_HELPER: [False, False, True, False],
88 db.DB_GROUP_CREATOR: [True, False, False, False],
89 db.DB_LEGACY: [False, False, False, False],
90 db.DB_LOCAL_SITE: [True, False, False, True],
91 db.DB_REPMGR_PEER: [False, False, False, False ],
128 self.dbenvMaster.rep_set_timeout(db.DB_REP_CONNECTION_RETRY,100123)
129 self.dbenvClient.rep_set_timeout(db.DB_REP_CONNECTION_RETRY,100321)
131 db.DB_REP_CONNECTION_RETRY), 100123)
133 db.DB_REP_CONNECTION_RETRY), 100321)
135 self.dbenvMaster.rep_set_timeout(db.DB_REP_ELECTION_TIMEOUT, 100234)
136 self.dbenvClient.rep_set_timeout(db.DB_REP_ELECTION_TIMEOUT, 100432)
138 db.DB_REP_ELECTION_TIMEOUT), 100234)
140 db.DB_REP_ELECTION_TIMEOUT), 100432)
142 self.dbenvMaster.rep_set_timeout(db.DB_REP_ELECTION_RETRY, 100345)
143 self.dbenvClient.rep_set_timeout(db.DB_REP_ELECTION_RETRY, 100543)
145 db.DB_REP_ELECTION_RETRY), 100345)
147 db.DB_REP_ELECTION_RETRY), 100543)
149 self.dbenvMaster.repmgr_set_ack_policy(db.DB_REPMGR_ACKS_ALL)
150 self.dbenvClient.repmgr_set_ack_policy(db.DB_REPMGR_ACKS_ALL)
152 self.dbenvMaster.repmgr_start(1, db.DB_REP_MASTER);
153 self.dbenvClient.repmgr_start(1, db.DB_REP_CLIENT);
160 db.DB_REPMGR_ACKS_ALL)
162 db.DB_REPMGR_ACKS_ALL)
189 self.assertTrue((d[2]==db.DB_REPMGR_CONNECTED) or \
190 (d[2]==db.DB_REPMGR_DISCONNECTED))
197 self.assertTrue((d[2]==db.DB_REPMGR_CONNECTED) or \
198 (d[2]==db.DB_REPMGR_DISCONNECTED))
200 if db.version() >= (4,6) :
201 d = self.dbenvMaster.repmgr_stat(flags=db.DB_STAT_CLEAR);
204 self.dbMaster=db.DB(self.dbenvMaster)
206 self.dbMaster.open("test", db.DB_HASH, db.DB_CREATE, 0666, txn=txn)
215 self.dbClient=db.DB(self.dbenvClient)
219 self.dbClient.open("test", db.DB_HASH, flags=db.DB_RDONLY,
221 except db.DBRepHandleDeadError :
224 self.dbClient=db.DB(self.dbenvClient)
270 if (b == db.DB_EVENT_REP_MASTER) or (b == db.DB_EVENT_REP_ELECTED) :
274 if b == db.DB_EVENT_REP_STARTUPDONE :
359 self.dbenvMaster.rep_start(flags=db.DB_REP_MASTER)
360 self.dbenvClient.rep_start(flags=db.DB_REP_CLIENT)
386 self.dbMaster=db.DB(self.dbenvMaster)
388 self.dbMaster.open("test", db.DB_HASH, db.DB_CREATE, 0666, txn=txn)
397 self.dbClient=db.DB(self.dbenvClient)
401 self.dbClient.open("test", db.DB_HASH, flags=db.DB_RDONLY,
403 except db.DBRepHandleDeadError :
406 self.dbClient=db.DB(self.dbenvClient)
412 d = self.dbenvMaster.rep_stat(flags=db.DB_STAT_CLEAR);
443 if db.version() >= (4,7) :
451 if db.version() >= (4,6) :
455 self.dbenvMaster.rep_start(flags=db.DB_REP_CLIENT)
456 self.dbenvClient.rep_start(flags=db.DB_REP_CLIENT)
464 self.dbenvMaster.rep_start(flags = db.DB_REP_MASTER)
467 if r[0] == db.DB_REP_HOLDELECTION :
474 except db.DBRepUnavailError :
492 self.dbenvMaster.rep_set_timeout(db.DB_REP_ELECTION_TIMEOUT, 50000)
493 self.dbenvClient.rep_set_timeout(db.DB_REP_ELECTION_TIMEOUT, 50000)
500 except db.DBRepUnavailError :
512 if db.version() >= (4,7) :
524 if db.version() >= (4, 6) :
525 dbenv = db.DBEnv()