Python code coverage for Lib/bsddb/test/test_replication.py

#	count	content
1	n/a	"""TestCases for distributed transactions.
2	n/a	"""
3	n/a
4	n/a	import os
5	n/a	import time
6	n/a	import unittest
7	n/a
8	n/a	from test_all import db, test_support, have_threads, verbose, \
9	n/a	get_new_environment_path, get_new_database_path
10	n/a
11	n/a
12	n/a	#----------------------------------------------------------------------
13	n/a
14	n/a	class DBReplication(unittest.TestCase) :
15	n/a	import sys
16	n/a	if sys.version_info < (2, 4) :
17	n/a	def assertTrue(self, expr, msg=None):
18	n/a	self.failUnless(expr,msg=msg)
19	n/a
20	n/a	def setUp(self) :
21	n/a	self.homeDirMaster = get_new_environment_path()
22	n/a	self.homeDirClient = get_new_environment_path()
23	n/a
24	n/a	self.dbenvMaster = db.DBEnv()
25	n/a	self.dbenvClient = db.DBEnv()
26	n/a
27	n/a	# Must use "DB_THREAD" because the Replication Manager will
28	n/a	# be executed in other threads but will use the same environment.
29	n/a	# http://forums.oracle.com/forums/thread.jspa?threadID=645788&tstart=0
30	n/a	self.dbenvMaster.open(self.homeDirMaster, db.DB_CREATE \| db.DB_INIT_TXN
31	n/a	\| db.DB_INIT_LOG \| db.DB_INIT_MPOOL \| db.DB_INIT_LOCK \|
32	n/a	db.DB_INIT_REP \| db.DB_RECOVER \| db.DB_THREAD, 0666)
33	n/a	self.dbenvClient.open(self.homeDirClient, db.DB_CREATE \| db.DB_INIT_TXN
34	n/a	\| db.DB_INIT_LOG \| db.DB_INIT_MPOOL \| db.DB_INIT_LOCK \|
35	n/a	db.DB_INIT_REP \| db.DB_RECOVER \| db.DB_THREAD, 0666)
36	n/a
37	n/a	self.confirmed_master=self.client_startupdone=False
38	n/a	def confirmed_master(a,b,c) :
39	n/a	if b==db.DB_EVENT_REP_MASTER :
40	n/a	self.confirmed_master=True
41	n/a
42	n/a	def client_startupdone(a,b,c) :
43	n/a	if b==db.DB_EVENT_REP_STARTUPDONE :
44	n/a	self.client_startupdone=True
45	n/a
46	n/a	self.dbenvMaster.set_event_notify(confirmed_master)
47	n/a	self.dbenvClient.set_event_notify(client_startupdone)
48	n/a
49	n/a	#self.dbenvMaster.set_verbose(db.DB_VERB_REPLICATION, True)
50	n/a	#self.dbenvMaster.set_verbose(db.DB_VERB_FILEOPS_ALL, True)
51	n/a	#self.dbenvClient.set_verbose(db.DB_VERB_REPLICATION, True)
52	n/a	#self.dbenvClient.set_verbose(db.DB_VERB_FILEOPS_ALL, True)
53	n/a
54	n/a	self.dbMaster = self.dbClient = None
55	n/a
56	n/a
57	n/a	def tearDown(self):
58	n/a	if self.dbClient :
59	n/a	self.dbClient.close()
60	n/a	if self.dbMaster :
61	n/a	self.dbMaster.close()
62	n/a
63	n/a	# Here we assign dummy event handlers to allow GC of the test object.
64	n/a	# Since the dummy handler doesn't use any outer scope variable, it
65	n/a	# doesn't keep any reference to the test object.
66	n/a	def dummy(*args) :
67	n/a	pass
68	n/a	self.dbenvMaster.set_event_notify(dummy)
69	n/a	self.dbenvClient.set_event_notify(dummy)
70	n/a
71	n/a	self.dbenvClient.close()
72	n/a	self.dbenvMaster.close()
73	n/a	test_support.rmtree(self.homeDirClient)
74	n/a	test_support.rmtree(self.homeDirMaster)
75	n/a
76	n/a	class DBReplicationManager(DBReplication) :
77	n/a	def test01_basic_replication(self) :
78	n/a	master_port = test_support.find_unused_port()
79	n/a	self.dbenvMaster.repmgr_set_local_site("127.0.0.1", master_port)
80	n/a	client_port = test_support.find_unused_port()
81	n/a	self.dbenvClient.repmgr_set_local_site("127.0.0.1", client_port)
82	n/a	self.dbenvMaster.repmgr_add_remote_site("127.0.0.1", client_port)
83	n/a	self.dbenvClient.repmgr_add_remote_site("127.0.0.1", master_port)
84	n/a	self.dbenvMaster.rep_set_nsites(2)
85	n/a	self.dbenvClient.rep_set_nsites(2)
86	n/a	self.dbenvMaster.rep_set_priority(10)
87	n/a	self.dbenvClient.rep_set_priority(0)
88	n/a
89	n/a	self.dbenvMaster.rep_set_timeout(db.DB_REP_CONNECTION_RETRY,100123)
90	n/a	self.dbenvClient.rep_set_timeout(db.DB_REP_CONNECTION_RETRY,100321)
91	n/a	self.assertEquals(self.dbenvMaster.rep_get_timeout(
92	n/a	db.DB_REP_CONNECTION_RETRY), 100123)
93	n/a	self.assertEquals(self.dbenvClient.rep_get_timeout(
94	n/a	db.DB_REP_CONNECTION_RETRY), 100321)
95	n/a
96	n/a	self.dbenvMaster.rep_set_timeout(db.DB_REP_ELECTION_TIMEOUT, 100234)
97	n/a	self.dbenvClient.rep_set_timeout(db.DB_REP_ELECTION_TIMEOUT, 100432)
98	n/a	self.assertEquals(self.dbenvMaster.rep_get_timeout(
99	n/a	db.DB_REP_ELECTION_TIMEOUT), 100234)
100	n/a	self.assertEquals(self.dbenvClient.rep_get_timeout(
101	n/a	db.DB_REP_ELECTION_TIMEOUT), 100432)
102	n/a
103	n/a	self.dbenvMaster.rep_set_timeout(db.DB_REP_ELECTION_RETRY, 100345)
104	n/a	self.dbenvClient.rep_set_timeout(db.DB_REP_ELECTION_RETRY, 100543)
105	n/a	self.assertEquals(self.dbenvMaster.rep_get_timeout(
106	n/a	db.DB_REP_ELECTION_RETRY), 100345)
107	n/a	self.assertEquals(self.dbenvClient.rep_get_timeout(
108	n/a	db.DB_REP_ELECTION_RETRY), 100543)
109	n/a
110	n/a	self.dbenvMaster.repmgr_set_ack_policy(db.DB_REPMGR_ACKS_ALL)
111	n/a	self.dbenvClient.repmgr_set_ack_policy(db.DB_REPMGR_ACKS_ALL)
112	n/a
113	n/a	self.dbenvMaster.repmgr_start(1, db.DB_REP_MASTER);
114	n/a	self.dbenvClient.repmgr_start(1, db.DB_REP_CLIENT);
115	n/a
116	n/a	self.assertEquals(self.dbenvMaster.rep_get_nsites(),2)
117	n/a	self.assertEquals(self.dbenvClient.rep_get_nsites(),2)
118	n/a	self.assertEquals(self.dbenvMaster.rep_get_priority(),10)
119	n/a	self.assertEquals(self.dbenvClient.rep_get_priority(),0)
120	n/a	self.assertEquals(self.dbenvMaster.repmgr_get_ack_policy(),
121	n/a	db.DB_REPMGR_ACKS_ALL)
122	n/a	self.assertEquals(self.dbenvClient.repmgr_get_ack_policy(),
123	n/a	db.DB_REPMGR_ACKS_ALL)
124	n/a
125	n/a	# The timeout is necessary in BDB 4.5, since DB_EVENT_REP_STARTUPDONE
126	n/a	# is not generated if the master has no new transactions.
127	n/a	# This is solved in BDB 4.6 (#15542).
128	n/a	import time
129	n/a	timeout = time.time()+60
130	n/a	while (time.time()<timeout) and not (self.confirmed_master and self.client_startupdone) :
131	n/a	time.sleep(0.02)
132	n/a	# self.client_startupdone does not always get set to True within
133	n/a	# the timeout. On windows this may be a deep issue, on other
134	n/a	# platforms it is likely just a timing issue, especially on slow
135	n/a	# virthost buildbots (see issue 3892 for more). Even though
136	n/a	# the timeout triggers, the rest of this test method usually passes
137	n/a	# (but not all of it always, see below). So we just note the
138	n/a	# timeout on stderr and keep soldering on.
139	n/a	if time.time()>timeout:
140	n/a	import sys
141	n/a	print >> sys.stderr, ("XXX: timeout happened before"
142	n/a	"startup was confirmed - see issue 3892")
143	n/a	startup_timeout = True
144	n/a
145	n/a	d = self.dbenvMaster.repmgr_site_list()
146	n/a	self.assertEquals(len(d), 1)
147	n/a	self.assertEquals(d[0][0], "127.0.0.1")
148	n/a	self.assertEquals(d[0][1], client_port)
149	n/a	self.assertTrue((d[0][2]==db.DB_REPMGR_CONNECTED) or \
150	n/a	(d[0][2]==db.DB_REPMGR_DISCONNECTED))
151	n/a
152	n/a	d = self.dbenvClient.repmgr_site_list()
153	n/a	self.assertEquals(len(d), 1)
154	n/a	self.assertEquals(d[0][0], "127.0.0.1")
155	n/a	self.assertEquals(d[0][1], master_port)
156	n/a	self.assertTrue((d[0][2]==db.DB_REPMGR_CONNECTED) or \
157	n/a	(d[0][2]==db.DB_REPMGR_DISCONNECTED))
158	n/a
159	n/a	if db.version() >= (4,6) :
160	n/a	d = self.dbenvMaster.repmgr_stat(flags=db.DB_STAT_CLEAR);
161	n/a	self.assertTrue("msgs_queued" in d)
162	n/a
163	n/a	self.dbMaster=db.DB(self.dbenvMaster)
164	n/a	txn=self.dbenvMaster.txn_begin()
165	n/a	self.dbMaster.open("test", db.DB_HASH, db.DB_CREATE, 0666, txn=txn)
166	n/a	txn.commit()
167	n/a
168	n/a	import time,os.path
169	n/a	timeout=time.time()+10
170	n/a	while (time.time()<timeout) and \
171	n/a	not (os.path.exists(os.path.join(self.homeDirClient,"test"))) :
172	n/a	time.sleep(0.01)
173	n/a
174	n/a	self.dbClient=db.DB(self.dbenvClient)
175	n/a	while True :
176	n/a	txn=self.dbenvClient.txn_begin()
177	n/a	try :
178	n/a	self.dbClient.open("test", db.DB_HASH, flags=db.DB_RDONLY,
179	n/a	mode=0666, txn=txn)
180	n/a	except db.DBRepHandleDeadError :
181	n/a	txn.abort()
182	n/a	self.dbClient.close()
183	n/a	self.dbClient=db.DB(self.dbenvClient)
184	n/a	continue
185	n/a
186	n/a	txn.commit()
187	n/a	break
188	n/a
189	n/a	txn=self.dbenvMaster.txn_begin()
190	n/a	self.dbMaster.put("ABC", "123", txn=txn)
191	n/a	txn.commit()
192	n/a	import time
193	n/a	timeout=time.time()+10
194	n/a	v=None
195	n/a	while (time.time()<timeout) and (v is None) :
196	n/a	txn=self.dbenvClient.txn_begin()
197	n/a	v=self.dbClient.get("ABC", txn=txn)
198	n/a	txn.commit()
199	n/a	if v is None :
200	n/a	time.sleep(0.02)
201	n/a	# If startup did not happen before the timeout above, then this test
202	n/a	# sometimes fails. This happens randomly, which causes buildbot
203	n/a	# instability, but all the other bsddb tests pass. Since bsddb3 in the
204	n/a	# stdlib is currently not getting active maintenance, and is gone in
205	n/a	# py3k, we just skip the end of the test in that case.
206	n/a	if time.time()>=timeout and startup_timeout:
207	n/a	self.skipTest("replication test skipped due to random failure, "
208	n/a	"see issue 3892")
209	n/a	self.assertTrue(time.time()<timeout)
210	n/a	self.assertEquals("123", v)
211	n/a
212	n/a	txn=self.dbenvMaster.txn_begin()
213	n/a	self.dbMaster.delete("ABC", txn=txn)
214	n/a	txn.commit()
215	n/a	timeout=time.time()+10
216	n/a	while (time.time()<timeout) and (v is not None) :
217	n/a	txn=self.dbenvClient.txn_begin()
218	n/a	v=self.dbClient.get("ABC", txn=txn)
219	n/a	txn.commit()
220	n/a	if v is None :
221	n/a	time.sleep(0.02)
222	n/a	self.assertTrue(time.time()<timeout)
223	n/a	self.assertEquals(None, v)
224	n/a
225	n/a	class DBBaseReplication(DBReplication) :
226	n/a	def setUp(self) :
227	n/a	DBReplication.setUp(self)
228	n/a	def confirmed_master(a,b,c) :
229	n/a	if (b == db.DB_EVENT_REP_MASTER) or (b == db.DB_EVENT_REP_ELECTED) :
230	n/a	self.confirmed_master = True
231	n/a
232	n/a	def client_startupdone(a,b,c) :
233	n/a	if b == db.DB_EVENT_REP_STARTUPDONE :
234	n/a	self.client_startupdone = True
235	n/a
236	n/a	self.dbenvMaster.set_event_notify(confirmed_master)
237	n/a	self.dbenvClient.set_event_notify(client_startupdone)
238	n/a
239	n/a	import Queue
240	n/a	self.m2c = Queue.Queue()
241	n/a	self.c2m = Queue.Queue()
242	n/a
243	n/a	# There are only two nodes, so we don't need to
244	n/a	# do any routing decision
245	n/a	def m2c(dbenv, control, rec, lsnp, envid, flags) :
246	n/a	self.m2c.put((control, rec))
247	n/a
248	n/a	def c2m(dbenv, control, rec, lsnp, envid, flags) :
249	n/a	self.c2m.put((control, rec))
250	n/a
251	n/a	self.dbenvMaster.rep_set_transport(13,m2c)
252	n/a	self.dbenvMaster.rep_set_priority(10)
253	n/a	self.dbenvClient.rep_set_transport(3,c2m)
254	n/a	self.dbenvClient.rep_set_priority(0)
255	n/a
256	n/a	self.assertEquals(self.dbenvMaster.rep_get_priority(),10)
257	n/a	self.assertEquals(self.dbenvClient.rep_get_priority(),0)
258	n/a
259	n/a	#self.dbenvMaster.set_verbose(db.DB_VERB_REPLICATION, True)
260	n/a	#self.dbenvMaster.set_verbose(db.DB_VERB_FILEOPS_ALL, True)
261	n/a	#self.dbenvClient.set_verbose(db.DB_VERB_REPLICATION, True)
262	n/a	#self.dbenvClient.set_verbose(db.DB_VERB_FILEOPS_ALL, True)
263	n/a
264	n/a	def thread_master() :
265	n/a	return self.thread_do(self.dbenvMaster, self.c2m, 3,
266	n/a	self.master_doing_election, True)
267	n/a
268	n/a	def thread_client() :
269	n/a	return self.thread_do(self.dbenvClient, self.m2c, 13,
270	n/a	self.client_doing_election, False)
271	n/a
272	n/a	from threading import Thread
273	n/a	t_m=Thread(target=thread_master)
274	n/a	t_c=Thread(target=thread_client)
275	n/a	import sys
276	n/a	if sys.version_info[0] < 3 :
277	n/a	t_m.setDaemon(True)
278	n/a	t_c.setDaemon(True)
279	n/a	else :
280	n/a	t_m.daemon = True
281	n/a	t_c.daemon = True
282	n/a
283	n/a	self.t_m = t_m
284	n/a	self.t_c = t_c
285	n/a
286	n/a	self.dbMaster = self.dbClient = None
287	n/a
288	n/a	self.master_doing_election=[False]
289	n/a	self.client_doing_election=[False]
290	n/a
291	n/a
292	n/a	def tearDown(self):
293	n/a	if self.dbClient :
294	n/a	self.dbClient.close()
295	n/a	if self.dbMaster :
296	n/a	self.dbMaster.close()
297	n/a	self.m2c.put(None)
298	n/a	self.c2m.put(None)
299	n/a	self.t_m.join()
300	n/a	self.t_c.join()
301	n/a
302	n/a	# Here we assign dummy event handlers to allow GC of the test object.
303	n/a	# Since the dummy handler doesn't use any outer scope variable, it
304	n/a	# doesn't keep any reference to the test object.
305	n/a	def dummy(*args) :
306	n/a	pass
307	n/a	self.dbenvMaster.set_event_notify(dummy)
308	n/a	self.dbenvClient.set_event_notify(dummy)
309	n/a	self.dbenvMaster.rep_set_transport(13,dummy)
310	n/a	self.dbenvClient.rep_set_transport(3,dummy)
311	n/a
312	n/a	self.dbenvClient.close()
313	n/a	self.dbenvMaster.close()
314	n/a	test_support.rmtree(self.homeDirClient)
315	n/a	test_support.rmtree(self.homeDirMaster)
316	n/a
317	n/a	def basic_rep_threading(self) :
318	n/a	self.dbenvMaster.rep_start(flags=db.DB_REP_MASTER)
319	n/a	self.dbenvClient.rep_start(flags=db.DB_REP_CLIENT)
320	n/a
321	n/a	def thread_do(env, q, envid, election_status, must_be_master) :
322	n/a	while True :
323	n/a	v=q.get()
324	n/a	if v is None : return
325	n/a	env.rep_process_message(v[0], v[1], envid)
326	n/a
327	n/a	self.thread_do = thread_do
328	n/a
329	n/a	self.t_m.start()
330	n/a	self.t_c.start()
331	n/a
332	n/a	def test01_basic_replication(self) :
333	n/a	self.basic_rep_threading()
334	n/a
335	n/a	# The timeout is necessary in BDB 4.5, since DB_EVENT_REP_STARTUPDONE
336	n/a	# is not generated if the master has no new transactions.
337	n/a	# This is solved in BDB 4.6 (#15542).
338	n/a	import time
339	n/a	timeout = time.time()+60
340	n/a	while (time.time()<timeout) and not (self.confirmed_master and
341	n/a	self.client_startupdone) :
342	n/a	time.sleep(0.02)
343	n/a	self.assertTrue(time.time()<timeout)
344	n/a
345	n/a	self.dbMaster=db.DB(self.dbenvMaster)
346	n/a	txn=self.dbenvMaster.txn_begin()
347	n/a	self.dbMaster.open("test", db.DB_HASH, db.DB_CREATE, 0666, txn=txn)
348	n/a	txn.commit()
349	n/a
350	n/a	import time,os.path
351	n/a	timeout=time.time()+10
352	n/a	while (time.time()<timeout) and \
353	n/a	not (os.path.exists(os.path.join(self.homeDirClient,"test"))) :
354	n/a	time.sleep(0.01)
355	n/a
356	n/a	self.dbClient=db.DB(self.dbenvClient)
357	n/a	while True :
358	n/a	txn=self.dbenvClient.txn_begin()
359	n/a	try :
360	n/a	self.dbClient.open("test", db.DB_HASH, flags=db.DB_RDONLY,
361	n/a	mode=0666, txn=txn)
362	n/a	except db.DBRepHandleDeadError :
363	n/a	txn.abort()
364	n/a	self.dbClient.close()
365	n/a	self.dbClient=db.DB(self.dbenvClient)
366	n/a	continue
367	n/a
368	n/a	txn.commit()
369	n/a	break
370	n/a
371	n/a	d = self.dbenvMaster.rep_stat(flags=db.DB_STAT_CLEAR);
372	n/a	self.assertTrue("master_changes" in d)
373	n/a
374	n/a	txn=self.dbenvMaster.txn_begin()
375	n/a	self.dbMaster.put("ABC", "123", txn=txn)
376	n/a	txn.commit()
377	n/a	import time
378	n/a	timeout=time.time()+10
379	n/a	v=None
380	n/a	while (time.time()<timeout) and (v is None) :
381	n/a	txn=self.dbenvClient.txn_begin()
382	n/a	v=self.dbClient.get("ABC", txn=txn)
383	n/a	txn.commit()
384	n/a	if v is None :
385	n/a	time.sleep(0.02)
386	n/a	self.assertTrue(time.time()<timeout)
387	n/a	self.assertEquals("123", v)
388	n/a
389	n/a	txn=self.dbenvMaster.txn_begin()
390	n/a	self.dbMaster.delete("ABC", txn=txn)
391	n/a	txn.commit()
392	n/a	timeout=time.time()+10
393	n/a	while (time.time()<timeout) and (v is not None) :
394	n/a	txn=self.dbenvClient.txn_begin()
395	n/a	v=self.dbClient.get("ABC", txn=txn)
396	n/a	txn.commit()
397	n/a	if v is None :
398	n/a	time.sleep(0.02)
399	n/a	self.assertTrue(time.time()<timeout)
400	n/a	self.assertEquals(None, v)
401	n/a
402	n/a	if db.version() >= (4,7) :
403	n/a	def test02_test_request(self) :
404	n/a	self.basic_rep_threading()
405	n/a	(minimum, maximum) = self.dbenvClient.rep_get_request()
406	n/a	self.dbenvClient.rep_set_request(minimum-1, maximum+1)
407	n/a	self.assertEqual(self.dbenvClient.rep_get_request(),
408	n/a	(minimum-1, maximum+1))
409	n/a
410	n/a	if db.version() >= (4,6) :
411	n/a	def test03_master_election(self) :
412	n/a	# Get ready to hold an election
413	n/a	#self.dbenvMaster.rep_start(flags=db.DB_REP_MASTER)
414	n/a	self.dbenvMaster.rep_start(flags=db.DB_REP_CLIENT)
415	n/a	self.dbenvClient.rep_start(flags=db.DB_REP_CLIENT)
416	n/a
417	n/a	def thread_do(env, q, envid, election_status, must_be_master) :
418	n/a	while True :
419	n/a	v=q.get()
420	n/a	if v is None : return
421	n/a	r = env.rep_process_message(v[0],v[1],envid)
422	n/a	if must_be_master and self.confirmed_master :
423	n/a	self.dbenvMaster.rep_start(flags = db.DB_REP_MASTER)
424	n/a	must_be_master = False
425	n/a
426	n/a	if r[0] == db.DB_REP_HOLDELECTION :
427	n/a	def elect() :
428	n/a	while True :
429	n/a	try :
430	n/a	env.rep_elect(2, 1)
431	n/a	election_status[0] = False
432	n/a	break
433	n/a	except db.DBRepUnavailError :
434	n/a	pass
435	n/a	if not election_status[0] and not self.confirmed_master :
436	n/a	from threading import Thread
437	n/a	election_status[0] = True
438	n/a	t=Thread(target=elect)
439	n/a	import sys
440	n/a	if sys.version_info[0] < 3 :
441	n/a	t.setDaemon(True)
442	n/a	else :
443	n/a	t.daemon = True
444	n/a	t.start()
445	n/a
446	n/a	self.thread_do = thread_do
447	n/a
448	n/a	self.t_m.start()
449	n/a	self.t_c.start()
450	n/a
451	n/a	self.dbenvMaster.rep_set_timeout(db.DB_REP_ELECTION_TIMEOUT, 50000)
452	n/a	self.dbenvClient.rep_set_timeout(db.DB_REP_ELECTION_TIMEOUT, 50000)
453	n/a	self.client_doing_election[0] = True
454	n/a	while True :
455	n/a	try :
456	n/a	self.dbenvClient.rep_elect(2, 1)
457	n/a	self.client_doing_election[0] = False
458	n/a	break
459	n/a	except db.DBRepUnavailError :
460	n/a	pass
461	n/a
462	n/a	self.assertTrue(self.confirmed_master)
463	n/a
464	n/a	if db.version() >= (4,7) :
465	n/a	def test04_test_clockskew(self) :
466	n/a	fast, slow = 1234, 1230
467	n/a	self.dbenvMaster.rep_set_clockskew(fast, slow)
468	n/a	self.assertEqual((fast, slow),
469	n/a	self.dbenvMaster.rep_get_clockskew())
470	n/a	self.basic_rep_threading()
471	n/a
472	n/a	#----------------------------------------------------------------------
473	n/a
474	n/a	def test_suite():
475	n/a	suite = unittest.TestSuite()
476	n/a	if db.version() >= (4, 6) :
477	n/a	dbenv = db.DBEnv()
478	n/a	try :
479	n/a	dbenv.repmgr_get_ack_policy()
480	n/a	ReplicationManager_available=True
481	n/a	except :
482	n/a	ReplicationManager_available=False
483	n/a	dbenv.close()
484	n/a	del dbenv
485	n/a	if ReplicationManager_available :
486	n/a	suite.addTest(unittest.makeSuite(DBReplicationManager))
487	n/a
488	n/a	if have_threads :
489	n/a	suite.addTest(unittest.makeSuite(DBBaseReplication))
490	n/a
491	n/a	return suite
492	n/a
493	n/a
494	n/a	if __name__ == '__main__':
495	n/a	unittest.main(defaultTest='test_suite')