Gecko [ beriskala.com ]

Name	Size	Permission	Date
__init__.py	0 B	-rw-r--r--	2025-01-08 14:13
__init__.pyc	143 B	-rw-r--r--	2025-01-08 14:13
__init__.pyo	143 B	-rw-r--r--	2025-01-08 14:13
test_all.py	18.7 KB	-rw-r--r--	2025-01-08 14:13
test_all.pyc	25.08 KB	-rw-r--r--	2025-01-08 14:13
test_all.pyo	25.08 KB	-rw-r--r--	2025-01-08 14:13
test_associate.py	15.32 KB	-rw-r--r--	2025-01-08 14:13
test_associate.pyc	20.71 KB	-rw-r--r--	2025-01-08 14:13
test_associate.pyo	20.71 KB	-rw-r--r--	2025-01-08 14:13
test_basics.py	35.4 KB	-rw-r--r--	2025-01-08 14:13
test_basics.pyc	34.22 KB	-rw-r--r--	2025-01-08 14:13
test_basics.pyo	34.22 KB	-rw-r--r--	2025-01-08 14:13
test_compare.py	14.79 KB	-rw-r--r--	2025-01-08 14:13
test_compare.pyc	20.24 KB	-rw-r--r--	2025-01-08 14:13
test_compare.pyo	20.24 KB	-rw-r--r--	2025-01-08 14:13
test_compat.py	4.43 KB	-rw-r--r--	2025-01-08 14:13
test_compat.pyc	5.48 KB	-rw-r--r--	2025-01-08 14:13
test_compat.pyo	5.48 KB	-rw-r--r--	2025-01-08 14:13
test_cursor_pget_bug.py	1.83 KB	-rw-r--r--	2025-01-08 14:13
test_cursor_pget_bug.pyc	2.69 KB	-rw-r--r--	2025-01-08 14:13
test_cursor_pget_bug.pyo	2.69 KB	-rw-r--r--	2025-01-08 14:13
test_db.py	5.66 KB	-rw-r--r--	2025-01-08 14:13
test_db.pyc	8.96 KB	-rw-r--r--	2025-01-08 14:13
test_db.pyo	8.96 KB	-rw-r--r--	2025-01-08 14:13
test_dbenv.py	18.78 KB	-rw-r--r--	2025-01-08 14:13
test_dbenv.pyc	22.59 KB	-rw-r--r--	2025-01-08 14:13
test_dbenv.pyo	22.59 KB	-rw-r--r--	2025-01-08 14:13
test_dbobj.py	2.35 KB	-rw-r--r--	2025-01-08 14:13
test_dbobj.pyc	3.49 KB	-rw-r--r--	2025-01-08 14:13
test_dbobj.pyo	3.49 KB	-rw-r--r--	2025-01-08 14:13
test_dbshelve.py	11.42 KB	-rw-r--r--	2025-01-08 14:13
test_dbshelve.pyc	14.48 KB	-rw-r--r--	2025-01-08 14:13
test_dbshelve.pyo	14.48 KB	-rw-r--r--	2025-01-08 14:13
test_dbtables.py	14.98 KB	-rw-r--r--	2025-01-08 14:13
test_dbtables.pyc	11.74 KB	-rw-r--r--	2025-01-08 14:13
test_dbtables.pyo	11.74 KB	-rw-r--r--	2025-01-08 14:13
test_distributed_transactions.py	4.76 KB	-rw-r--r--	2025-01-08 14:13
test_distributed_transactions.pyc	5.71 KB	-rw-r--r--	2025-01-08 14:13
test_distributed_transactions.pyo	5.71 KB	-rw-r--r--	2025-01-08 14:13
test_early_close.py	7.27 KB	-rw-r--r--	2025-01-08 14:13
test_early_close.pyc	6.81 KB	-rw-r--r--	2025-01-08 14:13
test_early_close.pyo	6.81 KB	-rw-r--r--	2025-01-08 14:13
test_fileid.py	1.79 KB	-rw-r--r--	2025-01-08 14:13
test_fileid.pyc	2.44 KB	-rw-r--r--	2025-01-08 14:13
test_fileid.pyo	2.44 KB	-rw-r--r--	2025-01-08 14:13
test_get_none.py	2.24 KB	-rw-r--r--	2025-01-08 14:13
test_get_none.pyc	2.91 KB	-rw-r--r--	2025-01-08 14:13
test_get_none.pyo	2.91 KB	-rw-r--r--	2025-01-08 14:13
test_join.py	3.09 KB	-rw-r--r--	2025-01-08 14:13
test_join.pyc	3.64 KB	-rw-r--r--	2025-01-08 14:13
test_join.pyo	3.64 KB	-rw-r--r--	2025-01-08 14:13
test_lock.py	6.44 KB	-rw-r--r--	2025-01-08 14:13
test_lock.pyc	6.08 KB	-rw-r--r--	2025-01-08 14:13
test_lock.pyo	6.08 KB	-rw-r--r--	2025-01-08 14:13
test_misc.py	4.68 KB	-rw-r--r--	2025-01-08 14:13
test_misc.pyc	5.17 KB	-rw-r--r--	2025-01-08 14:13
test_misc.pyo	5.17 KB	-rw-r--r--	2025-01-08 14:13
test_pickle.py	1.93 KB	-rw-r--r--	2025-01-08 14:13
test_pickle.pyc	2.85 KB	-rw-r--r--	2025-01-08 14:13
test_pickle.pyo	2.85 KB	-rw-r--r--	2025-01-08 14:13
test_queue.py	3.92 KB	-rw-r--r--	2025-01-08 14:13
test_queue.pyc	3.99 KB	-rw-r--r--	2025-01-08 14:13
test_queue.pyo	3.99 KB	-rw-r--r--	2025-01-08 14:13
test_recno.py	8.55 KB	-rw-r--r--	2025-01-08 14:13
test_recno.pyc	7.75 KB	-rw-r--r--	2025-01-08 14:13
test_recno.pyo	7.75 KB	-rw-r--r--	2025-01-08 14:13
test_replication.py	20.97 KB	-rw-r--r--	2025-01-08 14:13
test_replication.pyc	15.9 KB	-rw-r--r--	2025-01-08 14:13
test_replication.pyo	15.9 KB	-rw-r--r--	2025-01-08 14:13
test_sequence.py	5.15 KB	-rw-r--r--	2025-01-08 14:13
test_sequence.pyc	6.77 KB	-rw-r--r--	2025-01-08 14:13
test_sequence.pyo	6.77 KB	-rw-r--r--	2025-01-08 14:13
test_thread.py	15.54 KB	-rw-r--r--	2025-01-08 14:13
test_thread.pyc	15.36 KB	-rw-r--r--	2025-01-08 14:13
test_thread.pyo	15.36 KB	-rw-r--r--	2025-01-08 14:13

Rename

"""TestCases for distributed transactions.
"""

import os
import unittest

from test_all import db, test_support, get_new_environment_path, \
        get_new_database_path

from test_all import verbose

#----------------------------------------------------------------------

class DBTxn_distributed(unittest.TestCase):
    num_txns=1234
    nosync=True
    must_open_db=False
    def _create_env(self, must_open_db) :
        self.dbenv = db.DBEnv()
        self.dbenv.set_tx_max(self.num_txns)
        self.dbenv.set_lk_max_lockers(self.num_txns*2)
        self.dbenv.set_lk_max_locks(self.num_txns*2)
        self.dbenv.set_lk_max_objects(self.num_txns*2)
        if self.nosync :
            self.dbenv.set_flags(db.DB_TXN_NOSYNC,True)
        self.dbenv.open(self.homeDir, db.DB_CREATE | db.DB_THREAD |
                db.DB_RECOVER |
                db.DB_INIT_TXN | db.DB_INIT_LOG | db.DB_INIT_MPOOL |
                db.DB_INIT_LOCK, 0666)
        self.db = db.DB(self.dbenv)
        self.db.set_re_len(db.DB_GID_SIZE)
        if must_open_db :
            txn=self.dbenv.txn_begin()
            self.db.open(self.filename,
                    db.DB_QUEUE, db.DB_CREATE | db.DB_THREAD, 0666,
                    txn=txn)
            txn.commit()

def setUp(self) :
        self.homeDir = get_new_environment_path()
        self.filename = "test"
        return self._create_env(must_open_db=True)

def _destroy_env(self):
        if self.nosync or (db.version()[:2] == (4,6)):  # Known bug
            self.dbenv.log_flush()
        self.db.close()
        self.dbenv.close()

def tearDown(self):
        self._destroy_env()
        test_support.rmtree(self.homeDir)

def _recreate_env(self,must_open_db) :
        self._destroy_env()
        self._create_env(must_open_db)

def test01_distributed_transactions(self) :
        txns=set()
        adapt = lambda x : x
        import sys
        if sys.version_info[0] >= 3 :
            adapt = lambda x : bytes(x, "ascii")
    # Create transactions, "prepare" them, and
    # let them be garbage collected.
        for i in xrange(self.num_txns) :
            txn = self.dbenv.txn_begin()
            gid = "%%%dd" %db.DB_GID_SIZE
            gid = adapt(gid %i)
            self.db.put(i, gid, txn=txn, flags=db.DB_APPEND)
            txns.add(gid)
            txn.prepare(gid)
        del txn

self._recreate_env(self.must_open_db)

# Get "to be recovered" transactions but
    # let them be garbage collected.
        recovered_txns=self.dbenv.txn_recover()
        self.assertEqual(self.num_txns,len(recovered_txns))
        for gid,txn in recovered_txns :
            self.assertIn(gid, txns)
        del txn
        del recovered_txns

self._recreate_env(self.must_open_db)

# Get "to be recovered" transactions. Commit, abort and
    # discard them.
        recovered_txns=self.dbenv.txn_recover()
        self.assertEqual(self.num_txns,len(recovered_txns))
        discard_txns=set()
        committed_txns=set()
        state=0
        for gid,txn in recovered_txns :
            if state==0 or state==1:
                committed_txns.add(gid)
                txn.commit()
            elif state==2 :
                txn.abort()
            elif state==3 :
                txn.discard()
                discard_txns.add(gid)
                state=-1
            state+=1
        del txn
        del recovered_txns

self._recreate_env(self.must_open_db)

# Verify the discarded transactions are still
    # around, and dispose them.
        recovered_txns=self.dbenv.txn_recover()
        self.assertEqual(len(discard_txns),len(recovered_txns))
        for gid,txn in recovered_txns :
            txn.abort()
        del txn
        del recovered_txns

self._recreate_env(must_open_db=True)

# Be sure there are not pending transactions.
    # Check also database size.
        recovered_txns=self.dbenv.txn_recover()
        self.assertEqual(len(recovered_txns), 0)
        self.assertEqual(len(committed_txns),self.db.stat()["nkeys"])

class DBTxn_distributedSYNC(DBTxn_distributed):
    nosync=False

class DBTxn_distributed_must_open_db(DBTxn_distributed):
    must_open_db=True

class DBTxn_distributedSYNC_must_open_db(DBTxn_distributed):
    nosync=False
    must_open_db=True

#----------------------------------------------------------------------

def test_suite():
    suite = unittest.TestSuite()
    if db.version() >= (4,5) :
        suite.addTest(unittest.makeSuite(DBTxn_distributed))
        suite.addTest(unittest.makeSuite(DBTxn_distributedSYNC))
    if db.version() >= (4,6) :
        suite.addTest(unittest.makeSuite(DBTxn_distributed_must_open_db))
        suite.addTest(unittest.makeSuite(DBTxn_distributedSYNC_must_open_db))
    return suite

if __name__ == '__main__':
    unittest.main(defaultTest='test_suite')