Gecko [ beriskala.com ]

Name	Size	Permission	Date
__init__.py	0 B	-rw-r--r--	2024-04-10 08:28
__init__.pyc	130 B	-rw-r--r--	2024-04-10 08:28
__init__.pyo	130 B	-rw-r--r--	2024-04-10 08:28
test_all.py	18.7 KB	-rw-r--r--	2024-04-10 08:28
test_all.pyc	23.95 KB	-rw-r--r--	2024-04-10 08:28
test_all.pyo	23.95 KB	-rw-r--r--	2024-04-10 08:28
test_associate.py	15.32 KB	-rw-r--r--	2024-04-10 08:28
test_associate.pyc	20.14 KB	-rw-r--r--	2024-04-10 08:28
test_associate.pyo	20.14 KB	-rw-r--r--	2024-04-10 08:28
test_basics.py	35.4 KB	-rw-r--r--	2024-04-10 08:28
test_basics.pyc	33.32 KB	-rw-r--r--	2024-04-10 08:28
test_basics.pyo	33.32 KB	-rw-r--r--	2024-04-10 08:28
test_compare.py	14.79 KB	-rw-r--r--	2024-04-10 08:28
test_compare.pyc	19.28 KB	-rw-r--r--	2024-04-10 08:28
test_compare.pyo	19.28 KB	-rw-r--r--	2024-04-10 08:28
test_compat.py	4.43 KB	-rw-r--r--	2024-04-10 08:28
test_compat.pyc	5.3 KB	-rw-r--r--	2024-04-10 08:28
test_compat.pyo	5.3 KB	-rw-r--r--	2024-04-10 08:28
test_cursor_pget_bug.py	1.83 KB	-rw-r--r--	2024-04-10 08:28
test_cursor_pget_bug.pyc	2.6 KB	-rw-r--r--	2024-04-10 08:28
test_cursor_pget_bug.pyo	2.6 KB	-rw-r--r--	2024-04-10 08:28
test_db.py	5.66 KB	-rw-r--r--	2024-04-10 08:28
test_db.pyc	8.58 KB	-rw-r--r--	2024-04-10 08:28
test_db.pyo	8.58 KB	-rw-r--r--	2024-04-10 08:28
test_dbenv.py	18.78 KB	-rw-r--r--	2024-04-10 08:28
test_dbenv.pyc	21.78 KB	-rw-r--r--	2024-04-10 08:28
test_dbenv.pyo	21.78 KB	-rw-r--r--	2024-04-10 08:28
test_dbobj.py	2.35 KB	-rw-r--r--	2024-04-10 08:28
test_dbobj.pyc	3.35 KB	-rw-r--r--	2024-04-10 08:28
test_dbobj.pyo	3.35 KB	-rw-r--r--	2024-04-10 08:28
test_dbshelve.py	11.42 KB	-rw-r--r--	2024-04-10 08:28
test_dbshelve.pyc	13.95 KB	-rw-r--r--	2024-04-10 08:28
test_dbshelve.pyo	13.95 KB	-rw-r--r--	2024-04-10 08:28
test_dbtables.py	14.98 KB	-rw-r--r--	2024-04-10 08:28
test_dbtables.pyc	11.49 KB	-rw-r--r--	2024-04-10 08:28
test_dbtables.pyo	11.49 KB	-rw-r--r--	2024-04-10 08:28
test_distributed_transactions.py	4.76 KB	-rw-r--r--	2024-04-10 08:28
test_distributed_transactions.pyc	5.53 KB	-rw-r--r--	2024-04-10 08:28
test_distributed_transactions.pyo	5.53 KB	-rw-r--r--	2024-04-10 08:28
test_early_close.py	7.27 KB	-rw-r--r--	2024-04-10 08:28
test_early_close.pyc	6.66 KB	-rw-r--r--	2024-04-10 08:28
test_early_close.pyo	6.66 KB	-rw-r--r--	2024-04-10 08:28
test_fileid.py	1.79 KB	-rw-r--r--	2024-04-10 08:28
test_fileid.pyc	2.37 KB	-rw-r--r--	2024-04-10 08:28
test_fileid.pyo	2.37 KB	-rw-r--r--	2024-04-10 08:28
test_get_none.py	2.24 KB	-rw-r--r--	2024-04-10 08:28
test_get_none.pyc	2.82 KB	-rw-r--r--	2024-04-10 08:28
test_get_none.pyo	2.82 KB	-rw-r--r--	2024-04-10 08:28
test_join.py	3.09 KB	-rw-r--r--	2024-04-10 08:28
test_join.pyc	3.54 KB	-rw-r--r--	2024-04-10 08:28
test_join.pyo	3.54 KB	-rw-r--r--	2024-04-10 08:28
test_lock.py	6.44 KB	-rw-r--r--	2024-04-10 08:28
test_lock.pyc	5.94 KB	-rw-r--r--	2024-04-10 08:28
test_lock.pyo	5.94 KB	-rw-r--r--	2024-04-10 08:28
test_misc.py	4.68 KB	-rw-r--r--	2024-04-10 08:28
test_misc.pyc	5.01 KB	-rw-r--r--	2024-04-10 08:28
test_misc.pyo	5.01 KB	-rw-r--r--	2024-04-10 08:28
test_pickle.py	1.93 KB	-rw-r--r--	2024-04-10 08:28
test_pickle.pyc	2.75 KB	-rw-r--r--	2024-04-10 08:28
test_pickle.pyo	2.75 KB	-rw-r--r--	2024-04-10 08:28
test_queue.py	3.92 KB	-rw-r--r--	2024-04-10 08:28
test_queue.pyc	3.9 KB	-rw-r--r--	2024-04-10 08:28
test_queue.pyo	3.9 KB	-rw-r--r--	2024-04-10 08:28
test_recno.py	8.55 KB	-rw-r--r--	2024-04-10 08:28
test_recno.pyc	7.61 KB	-rw-r--r--	2024-04-10 08:28
test_recno.pyo	7.61 KB	-rw-r--r--	2024-04-10 08:28
test_replication.py	20.97 KB	-rw-r--r--	2024-04-10 08:28
test_replication.pyc	15.54 KB	-rw-r--r--	2024-04-10 08:28
test_replication.pyo	15.54 KB	-rw-r--r--	2024-04-10 08:28
test_sequence.py	5.15 KB	-rw-r--r--	2024-04-10 08:28
test_sequence.pyc	6.56 KB	-rw-r--r--	2024-04-10 08:28
test_sequence.pyo	6.56 KB	-rw-r--r--	2024-04-10 08:28
test_thread.py	15.54 KB	-rw-r--r--	2024-04-10 08:28
test_thread.pyc	14.97 KB	-rw-r--r--	2024-04-10 08:28
test_thread.pyo	14.97 KB	-rw-r--r--	2024-04-10 08:28

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')