diff options
Diffstat (limited to 'Lib/bsddb/test/test_replication.py')
| -rw-r--r-- | Lib/bsddb/test/test_replication.py | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/Lib/bsddb/test/test_replication.py b/Lib/bsddb/test/test_replication.py index b3775c7..1817e60 100644 --- a/Lib/bsddb/test/test_replication.py +++ b/Lib/bsddb/test/test_replication.py @@ -188,11 +188,11 @@ class DBReplicationManager(unittest.TestCase): import time timeout=time.time()+10 v=None - while (time.time()<timeout) and (v==None) : + while (time.time()<timeout) and (v is None) : txn=self.dbenvClient.txn_begin() v=self.dbClient.get("ABC", txn=txn) txn.commit() - if v==None : + if v is None : time.sleep(0.02) self.assertTrue(time.time()<timeout) self.assertEquals("123", v) @@ -201,11 +201,11 @@ class DBReplicationManager(unittest.TestCase): self.dbMaster.delete("ABC", txn=txn) txn.commit() timeout=time.time()+10 - while (time.time()<timeout) and (v!=None) : + while (time.time()<timeout) and (v is not None) : txn=self.dbenvClient.txn_begin() v=self.dbClient.get("ABC", txn=txn) txn.commit() - if v==None : + if v is None : time.sleep(0.02) self.assertTrue(time.time()<timeout) self.assertEquals(None, v) @@ -298,7 +298,7 @@ class DBBaseReplication(DBReplicationManager): def thread_do(env, q, envid, election_status, must_be_master) : while True : v=q.get() - if v == None : return + if v is None : return env.rep_process_message(v[0], v[1], envid) self.thread_do = thread_do @@ -351,11 +351,11 @@ class DBBaseReplication(DBReplicationManager): import time timeout=time.time()+10 v=None - while (time.time()<timeout) and (v==None) : + while (time.time()<timeout) and (v is None) : txn=self.dbenvClient.txn_begin() v=self.dbClient.get("ABC", txn=txn) txn.commit() - if v==None : + if v is None : time.sleep(0.02) self.assertTrue(time.time()<timeout) self.assertEquals("123", v) @@ -364,11 +364,11 @@ class DBBaseReplication(DBReplicationManager): self.dbMaster.delete("ABC", txn=txn) txn.commit() timeout=time.time()+10 - while (time.time()<timeout) and (v!=None) : + while (time.time()<timeout) and (v is not None) : txn=self.dbenvClient.txn_begin() v=self.dbClient.get("ABC", txn=txn) txn.commit() - if v==None : + if v is None : time.sleep(0.02) self.assertTrue(time.time()<timeout) self.assertEquals(None, v) @@ -391,7 +391,7 @@ class DBBaseReplication(DBReplicationManager): def thread_do(env, q, envid, election_status, must_be_master) : while True : v=q.get() - if v == None : return + if v is None : return r = env.rep_process_message(v[0],v[1],envid) if must_be_master and self.confirmed_master : self.dbenvMaster.rep_start(flags = db.DB_REP_MASTER) |