BTreeTxnTest Class Reference

Inheritance diagram for BTreeTxnTest:

List of all members.

Public Member Functions
	BTreeTxnTest ()
virtual void	testCaseSetUp ()
	Equivalent to JUnit TestCase.setUp; this is called before each test case method is invoked.
virtual void	testCaseTearDown ()
	Equivalent to JUnit TestCase.tearDown; this is called after each test case method is invoked.
virtual void	threadInit ()
virtual void	threadTerminate ()
virtual bool	testThreadedOp (int iOp)
	Test implementation must be supplied by derived test class.
TestSuite *	releaseTestSuite ()
void	beforeTestCase (std::string testCaseName)
void	afterTestCase (std::string testCaseName)
virtual void	notifyTrace (std::string source, TraceLevel level, std::string message)
	Receives notification when a trace event occurs.
virtual TraceLevel	getSourceTraceLevel (std::string source)
	Gets the level at which a particular source should be traced.
Static Public Member Functions
static void	readParams (int argc, char **argv)
	Parses the command line.
Static Public Attributes
static ParamName	paramTestSuiteName
static ParamName	paramTraceFileName
static ParamName	paramDictionaryFileName
static ParamName	paramTraceLevel
static ParamName	paramStatsFileName
static ParamName	paramTraceStdout
static ParamName	paramDegreeOfParallelism
static ConfigMap	configMap
	Configuration parameters.
Protected Member Functions
void	runThreadedTestCase ()
	Executes specified test threads.
void	snooze (uint nSeconds)
Protected Attributes
uint	nSeconds
	Duration of multi-threaded test.
std::vector< int >	threadCounts
	Number of threads to run for each type of operation.
TestSuite *	pTestSuite
	Boost test suite.
boost::shared_ptr< TestBase >	pTestObj
std::ofstream	traceStream
	Output file stream for tracing.
StrictMutex	traceMutex
	Protects traceStream.
std::string	testName
	Name of test.
TraceLevel	traceLevel
	Level at which to trace test execution.
FileStatsTarget	statsTarget
	Output for stats.
StatsTimer	statsTimer
	Timer for stats collection.
bool	traceStdout
	Copy trace output to stdout.
bool	traceFile
	Copy trace output to file.
TestCaseGroup	defaultTests
TestCaseGroup	extraTests
Static Protected Attributes
static bool	runAll
	Run all test cases, including the extra tests.
static std::string	runSingle
	Run only the test case of this name.
Private Types
enum	OpType {   OP_INSERT, OP_DELETE, OP_SCAN, OP_CHECKPOINT,   OP_MAX }
	The various operations that can be run in the multi-threaded test. More...
Private Member Functions
void	testTxns ()
void	insertTxn ()
void	deleteTxn ()
void	scanTxn ()
void	testCheckpoint ()
void	endTxn (SharedLogicalTxn pTxn)
uint	generateRandomNumber (uint iMax)
void	createTree ()
RecordNum	verifyTree ()
BTreeReader &	getReader ()
BTreeWriter &	getWriter ()
TupleData &	getKeyData ()
void	bindKey (int32_t &key)
Private Attributes
SharedCache	pCache
SharedDatabase	pDatabase
BTreeDescriptor	treeDescriptor
boost::thread_specific_ptr< TestThreadData >	pTestThreadData
PageId	rootPageId
bool	testRollback
uint	iKeyMax
uint	nInsertsPerTxn
uint	nDeletesPerTxn
uint	nKeysPerScan
uint	nSecondsBetweenCheckpoints
Classes
struct	Record
struct	TestThreadData

---

Detailed Description

Definition at line 49 of file BTreeTxnTest.cpp.

---

Member Enumeration Documentation

enum BTreeTxnTest::OpType [private]

The various operations that can be run in the multi-threaded test.

Enumerator:

OP_INSERT
OP_DELETE
OP_SCAN
OP_CHECKPOINT
OP_MAX

Definition at line 63 of file BTreeTxnTest.cpp.

                {
        OP_INSERT,
        OP_DELETE,
        OP_SCAN,
        OP_CHECKPOINT,
        OP_MAX
    };

---

Constructor & Destructor Documentation

BTreeTxnTest::BTreeTxnTest

(

)

[explicit]

Definition at line 123 of file BTreeTxnTest.cpp.

References TestBase::configMap, ConfigMap::getIntParam(), iKeyMax, nDeletesPerTxn, nInsertsPerTxn, nKeysPerScan, ThreadedTestBase::nSeconds, nSecondsBetweenCheckpoints, OP_CHECKPOINT, OP_DELETE, OP_INSERT, OP_MAX, OP_SCAN, testRollback, testTxns(), and ThreadedTestBase::threadCounts.

{
    nInsertsPerTxn = configMap.getIntParam("insertsPerTxn",5);
    nDeletesPerTxn = configMap.getIntParam("deletesPerTxn",5);
    nKeysPerScan = configMap.getIntParam("keysPerScan",5);
    iKeyMax = configMap.getIntParam("maxKey",1000000);
    nSecondsBetweenCheckpoints = configMap.getIntParam("checkpointInterval",20);
    testRollback = configMap.getIntParam(
        "testRollback",1);

    threadCounts.resize(OP_MAX,-1);

    threadCounts[OP_INSERT] = configMap.getIntParam(
        "insertThreads",-1);
    threadCounts[OP_DELETE] = configMap.getIntParam(
        "deleteThreads",-1);
    threadCounts[OP_SCAN] = configMap.getIntParam(
        "scanThreads",-1);

    if (nSecondsBetweenCheckpoints < nSeconds) {
        threadCounts[OP_CHECKPOINT] = 1;
    } else {
        threadCounts[OP_CHECKPOINT] = 0;
    }

    FENNEL_UNIT_TEST_CASE(BTreeTxnTest,testTxns);
}

---

Member Function Documentation

void BTreeTxnTest::testTxns

(

)

[private]

Definition at line 259 of file BTreeTxnTest.cpp.

References StatsTimer::addSource(), CHECKPOINT_DISCARD, TestBase::configMap, DeviceMode::load, Database::newDatabase(), pCache, pDatabase, SegmentAccessor::pSegment, SegmentAccessor::reset(), ThreadedTestBase::runThreadedTestCase(), BTreeDescriptor::segmentAccessor, StatsTimer::start(), TestBase::statsTimer, StatsTimer::stop(), treeDescriptor, and verifyTree().

Referenced by BTreeTxnTest().

{
    runThreadedTestCase();
    RecordNum nEntries = verifyTree();
    pDatabase->checkpointImpl(CHECKPOINT_DISCARD);

    statsTimer.stop();
    pDatabase.reset();
    pDatabase = Database::newDatabase(
        pCache,
        configMap,
        DeviceMode::load,
        shared_from_this());
    BOOST_CHECK(pDatabase->isRecoveryRequired());

    StandardTypeDescriptorFactory typeFactory;
    SegmentAccessor scratchAccessor =
        pDatabase->getSegmentFactory()->newScratchSegment(
            pCache,
            1);
    SegmentAccessor segmentAccessor(pDatabase->getDataSegment(),pCache);
    BTreeRecoveryFactory btreeRecoveryFactory(
        segmentAccessor,
        scratchAccessor,
        typeFactory);
    segmentAccessor.reset();
    scratchAccessor.reset();
    pDatabase->recover(btreeRecoveryFactory);

    // Don't restart the stats timer until after recovery has completed.
    statsTimer.addSource(pDatabase);
    statsTimer.start();

    treeDescriptor.segmentAccessor.pSegment = pDatabase->getDataSegment();
    RecordNum nEntriesRecovered = verifyTree();

    // FIXME jvs 8-Mar-2004:  Turn this back on once NOTE above is taken
    // care of.  Tautological checks are just to shut warnings up.

    // BOOST_CHECK_EQUAL(nEntries,nEntriesRecovered);
    BOOST_CHECK_EQUAL(nEntries,nEntries);
    BOOST_CHECK_EQUAL(nEntriesRecovered,nEntriesRecovered);
}

void BTreeTxnTest::insertTxn

(

)

[private]

Definition at line 303 of file BTreeTxnTest.cpp.

References DUP_DISCARD, endTxn(), generateRandomNumber(), getWriter(), iKeyMax, BTreeWriter::insertTupleFromBuffer(), nInsertsPerTxn, pCache, pDatabase, and pTestThreadData.

Referenced by testThreadedOp().

{
    SharedLogicalTxn pTxn = pDatabase->getTxnLog()->newLogicalTxn(pCache);
    pTxn->addParticipant(pTestThreadData->pWriter);
    BTreeWriter &writer = getWriter();
    for (uint i = 0; i < nInsertsPerTxn; ++i) {
        Record record;
        record.key = generateRandomNumber(iKeyMax);
        record.value = generateRandomNumber(iKeyMax);
        // TODO:  test with and without duplicates
        writer.insertTupleFromBuffer(
            reinterpret_cast<PConstBuffer>(&record),DUP_DISCARD);
    }
    endTxn(pTxn);
}

void BTreeTxnTest::deleteTxn

(

)

[private]

Definition at line 319 of file BTreeTxnTest.cpp.

References bindKey(), BTreeWriter::deleteCurrent(), DUP_SEEK_ANY, BTreeReader::endSearch(), endTxn(), generateRandomNumber(), getKeyData(), getWriter(), iKeyMax, nDeletesPerTxn, pCache, pDatabase, pTestThreadData, and BTreeReader::searchForKey().

Referenced by testThreadedOp().

{
    SharedLogicalTxn pTxn = pDatabase->getTxnLog()->newLogicalTxn(pCache);
    pTxn->addParticipant(pTestThreadData->pWriter);
    BTreeWriter &writer = getWriter();
    for (uint i = 0; i < nDeletesPerTxn; ++i) {
        int32_t key = generateRandomNumber(iKeyMax);
        bindKey(key);
        if (writer.searchForKey(getKeyData(),DUP_SEEK_ANY)) {
            writer.deleteCurrent();
        }
        writer.endSearch();
    }
    endTxn(pTxn);
}

void BTreeTxnTest::scanTxn

(

)

[private]

Definition at line 335 of file BTreeTxnTest.cpp.

References bindKey(), DUP_SEEK_ANY, BTreeReader::endSearch(), generateRandomNumber(), getKeyData(), getReader(), iKeyMax, nKeysPerScan, BTreeReader::searchForKey(), and BTreeReader::searchNext().

Referenced by testThreadedOp().

{
    BTreeReader &reader = getReader();
    int32_t key = generateRandomNumber(iKeyMax);
    bindKey(key);
    if (reader.searchForKey(getKeyData(),DUP_SEEK_ANY)) {
        for (uint i = 0; i < nKeysPerScan; ++i) {
            if (!reader.searchNext()) {
                break;
            }
        }
    }
    reader.endSearch();
}

void BTreeTxnTest::testCheckpoint

(

)

[private]

Definition at line 395 of file BTreeTxnTest.cpp.

References CHECKPOINT_FLUSH_ALL, CHECKPOINT_FLUSH_FUZZY, TestBase::configMap, ConfigMap::getIntParam(), nSecondsBetweenCheckpoints, pDatabase, and TestBase::snooze().

Referenced by testThreadedOp().

{
    snooze(nSecondsBetweenCheckpoints);
    CheckpointType checkpointType;
    if (configMap.getIntParam("fuzzyCheckpoint",1)) {
        checkpointType = CHECKPOINT_FLUSH_FUZZY;
    } else {
        checkpointType = CHECKPOINT_FLUSH_ALL;
    }
    pDatabase->requestCheckpoint(checkpointType,false);
}

void BTreeTxnTest::endTxn

(

SharedLogicalTxn

pTxn

)

[private]

Definition at line 350 of file BTreeTxnTest.cpp.

References generateRandomNumber(), and testRollback.

Referenced by deleteTxn(), and insertTxn().

{
    if (testRollback) {
        if (generateRandomNumber(2)) {
            pTxn->commit();
        } else {
            pTxn->rollback();
        }
    } else {
        pTxn->commit();
    }
}

uint BTreeTxnTest::generateRandomNumber

(

uint

iMax

)

[private]

Definition at line 235 of file BTreeTxnTest.cpp.

References pTestThreadData.

Referenced by deleteTxn(), endTxn(), insertTxn(), and scanTxn().

{
    return pTestThreadData->randomNumberGenerator(iMax);
}

void BTreeTxnTest::createTree

(

)

[private]

Definition at line 193 of file BTreeTxnTest.cpp.

References BTreeDescriptor::keyProjection, StandardTypeDescriptorFactory::newDataType(), pCache, SegmentAccessor::pCacheAccessor, pDatabase, SegmentAccessor::pSegment, rootPageId, BTreeDescriptor::rootPageId, BTreeDescriptor::segmentAccessor, STANDARD_TYPE_INT_32, treeDescriptor, and BTreeDescriptor::tupleDescriptor.

Referenced by testCaseSetUp().

{
    TupleDescriptor &tupleDesc = treeDescriptor.tupleDescriptor;
    StandardTypeDescriptorFactory stdTypeFactory;
    TupleAttributeDescriptor attrDesc(
        stdTypeFactory.newDataType(STANDARD_TYPE_INT_32));
    tupleDesc.push_back(attrDesc);
    tupleDesc.push_back(attrDesc);
    TupleProjection &keyProj = treeDescriptor.keyProjection;
    keyProj.push_back(0);

    treeDescriptor.segmentAccessor.pSegment = pDatabase->getDataSegment();
    treeDescriptor.segmentAccessor.pCacheAccessor = pCache;
    treeDescriptor.rootPageId = rootPageId;

    BTreeBuilder builder(treeDescriptor,pDatabase->getDataSegment());
    builder.createEmptyRoot();
    treeDescriptor.rootPageId = builder.getRootPageId();
}

RecordNum BTreeTxnTest::verifyTree

(

)

[private]

Definition at line 407 of file BTreeTxnTest.cpp.

References BTreeVerifier::getStatistics(), BTreeStatistics::nLeafNodes, BTreeStatistics::nLevels, BTreeStatistics::nNonLeafNodes, BTreeStatistics::nTuples, treeDescriptor, and BTreeVerifier::verify().

Referenced by testTxns().

{
    BTreeVerifier verifier(treeDescriptor);
    verifier.verify(false);

    BTreeStatistics const &stats = verifier.getStatistics();
    BOOST_MESSAGE("height = " << stats.nLevels);
    BOOST_MESSAGE("record count = " << stats.nTuples);
    BOOST_MESSAGE("leaf nodes = " << stats.nLeafNodes);
    BOOST_MESSAGE("nonleaf nodes = " << stats.nNonLeafNodes);
    return stats.nTuples;
}

BTreeReader & BTreeTxnTest::getReader

(

)

[private]

Definition at line 240 of file BTreeTxnTest.cpp.

References pTestThreadData.

Referenced by scanTxn(), and threadInit().

{
    return *(pTestThreadData->pReader);
}

BTreeWriter & BTreeTxnTest::getWriter

(

)

[private]

Definition at line 250 of file BTreeTxnTest.cpp.

References pTestThreadData.

Referenced by deleteTxn(), and insertTxn().

{
    return *(pTestThreadData->pWriter);
}

TupleData & BTreeTxnTest::getKeyData

(

)

[private]

Definition at line 245 of file BTreeTxnTest.cpp.

References pTestThreadData.

Referenced by bindKey(), deleteTxn(), and scanTxn().

{
    return pTestThreadData->keyData;
}

void BTreeTxnTest::bindKey

(

int32_t &

key

)

[private]

Definition at line 390 of file BTreeTxnTest.cpp.

References getKeyData().

Referenced by deleteTxn(), and scanTxn().

{
    getKeyData()[0].pData = reinterpret_cast<PConstBuffer>(&key);
}

void BTreeTxnTest::testCaseSetUp

(

)

[virtual]

Equivalent to JUnit TestCase.setUp; this is called before each test case method is invoked.

Default is no-op.

Reimplemented from TestBase.

Definition at line 151 of file BTreeTxnTest.cpp.

References StatsTimer::addSource(), TestBase::configMap, DeviceMode::createNew, createTree(), ConfigMap::isParamSet(), Cache::newCache(), Database::newDatabase(), NULL_PAGE_ID, Database::paramDatabaseDir, pCache, pDatabase, CacheParams::readConfig(), rootPageId, ConfigMap::setStringParam(), StatsTimer::start(), and TestBase::statsTimer.

{
    // TODO:  cleanup

    configMap.setStringParam(
        Database::paramDatabaseDir,".");
    configMap.setStringParam(
        "databaseInitSize","1000");
    configMap.setStringParam(
        "tempInitSize","1000");
    configMap.setStringParam(
        "databaseShadowLogInitSize","2000");
    if (!configMap.isParamSet("databaseTxnLogInitSize")) {
        configMap.setStringParam(
            "databaseTxnLogInitSize","2000");
    }

    CacheParams cacheParams;
    cacheParams.readConfig(configMap);
    pCache = Cache::newCache(cacheParams);
    pDatabase = Database::newDatabase(
        pCache,
        configMap,
        DeviceMode::createNew,
        shared_from_this());

    statsTimer.addSource(pDatabase);
    statsTimer.start();

    rootPageId = NULL_PAGE_ID;
    createTree();
    pDatabase->checkpointImpl();
}

void BTreeTxnTest::testCaseTearDown

(

)

[virtual]

Equivalent to JUnit TestCase.tearDown; this is called after each test case method is invoked.

Default is no-op.

Reimplemented from TestBase.

Definition at line 185 of file BTreeTxnTest.cpp.

References pCache, pDatabase, TestBase::statsTimer, and StatsTimer::stop().

{
    statsTimer.stop();

    pDatabase.reset();
    pCache.reset();
}

void BTreeTxnTest::threadInit

(

)

[virtual]

Reimplemented from ThreadedTestBase.

Definition at line 213 of file BTreeTxnTest.cpp.

References getReader(), pCache, pDatabase, pTestThreadData, ThreadedTestBase::threadInit(), and treeDescriptor.

{
    ThreadedTestBase::threadInit();
    pTestThreadData.reset(new TestThreadData());
    pTestThreadData->pReader.reset(new BTreeReader(treeDescriptor));
    pTestThreadData->keyData.compute(getReader().getKeyDescriptor());

    SegmentAccessor scratchAccessor =
        pDatabase->getSegmentFactory()->newScratchSegment(
            pCache,
            1);

    pTestThreadData->pWriter.reset(
        new BTreeWriter(treeDescriptor,scratchAccessor));
}

void BTreeTxnTest::threadTerminate

(

)

[virtual]

Reimplemented from ThreadedTestBase.

Definition at line 229 of file BTreeTxnTest.cpp.

References pTestThreadData, and ThreadedTestBase::threadTerminate().

{
    pTestThreadData.reset();
    ThreadedTestBase::threadTerminate();
}

bool BTreeTxnTest::testThreadedOp

(

int

iOp

)

[virtual]

Test implementation must be supplied by derived test class.

Parameters:

iOp

operation type to test

Returns:

true if test should run again

Implements ThreadedTestBase.

Definition at line 363 of file BTreeTxnTest.cpp.

References deleteTxn(), insertTxn(), OP_CHECKPOINT, OP_DELETE, OP_INSERT, OP_MAX, OP_SCAN, pDatabase, scanTxn(), and testCheckpoint().

{
    SXMutexSharedGuard checkpointSharedGuard(
        pDatabase->getCheckpointThread()->getActionMutex(),false);
    assert(iOp < OP_MAX);
    OpType op = static_cast<OpType>(iOp);
    switch (op) {
    case OP_INSERT:
        checkpointSharedGuard.lock();
        insertTxn();
        break;
    case OP_DELETE:
        checkpointSharedGuard.lock();
        deleteTxn();
        break;
    case OP_SCAN:
        scanTxn();
        break;
    case OP_CHECKPOINT:
        testCheckpoint();
        break;
    default:
        permAssert(false);
    }
    return true;
}

void ThreadedTestBase::runThreadedTestCase

(

)

[protected, inherited]

Executes specified test threads.

Definition at line 43 of file ThreadedTestBase.cpp.

References ThreadedTestBase::bDone, ThreadedTestBase::defaultThreadCount, ThreadedTestBase::nSeconds, ThreadedTestBase::pStartBarrier, TestBase::snooze(), ThreadPoolBase::start(), ThreadPoolBase::stop(), ThreadPool< Task >::submitTask(), and ThreadedTestBase::threadCounts.

Referenced by PagingTestBase::testMultipleThreads(), and testTxns().

{
    bDone = false;

    // materialize default thread counts
    std::replace_if(
        threadCounts.begin(),
        threadCounts.end(),
        std::bind2nd(std::equal_to<int>(),-1),
        defaultThreadCount);

    // calculate how many threads are needed
    int nThreads = std::accumulate(
        threadCounts.begin(),
        threadCounts.end(),
        0);

    // initialize a barrier to make sure they all start at once
    pStartBarrier.reset(new boost::barrier(nThreads));

    // fire 'em up
    ThreadPool<ThreadedTestBaseTask> threadPool;
    threadPool.start(nThreads);

    // and distribute the tasks
    for (uint i = 0; i < threadCounts.size(); ++i) {
        for (int j = 0; j < threadCounts[i]; ++j) {
            ThreadedTestBaseTask task(*this,i);
            threadPool.submitTask(task);
        }
    }

    // run the tests for the requested duration
    snooze(nSeconds);

    // tell threads to quit and then wait for them to finish up
    bDone = true;
    threadPool.stop();
}

void TestBase::snooze

(

uint

nSeconds

)

[protected, inherited]

Definition at line 263 of file TestBase.cpp.

Referenced by DatabaseTest::executeForceTxn(), ThreadedTestBase::runThreadedTestCase(), PagingTestBase::testCacheResize(), testCheckpoint(), PagingTestBase::testCheckpointGuarded(), PagingTestBase::testPrefetch(), and PagingTestBase::testPrefetchBatch().

{
#ifdef __MSVC__
    ::_sleep(nSeconds*1000);
#else
    ::sleep(nSeconds);
#endif
}

void TestBase::readParams	(	int	argc,
		char **	argv
	)			[static, inherited]

Parses the command line.

format: [-v] [-t TEST | -all] {param=val}* [CONFIGFILE | -] Normally, the test program runs the default test cases. With the option "-all", runs the extra test cases as well. With the option "-t TEST", runs only the single test case named TEST. CONFIGFILE is read to load configuration parameters. Configuration parameters can also be set ad hoc, from the command line, as pairs name=val. These take precedence.

Definition at line 108 of file TestBase.cpp.

References TestBase::configMap, ConfigMap::dumpParams(), ConfigMap::isParamSet(), ConfigMap::mergeFrom(), TestBase::paramDictionaryFileName, ConfigMap::readParams(), TestBase::runAll, TestBase::runSingle, ConfigMap::setStringParam(), and verbose.

{
    bool verbose = false;
    ConfigMap adhocMap;

    for (int i = 1; i < argc; ++i) {
        std::string arg = argv[i];
        if (argv[i][0] == '-') {
            if (arg == "-v") {
                verbose = true;
            } else if (arg == "-") {
                configMap.readParams(std::cin);
            } else if (arg == "-all") {
                runAll = true;
            } else if (arg == "-t") {   // -t TEST
                permAssert(i + 1 < argc);
                runSingle = argv[++i];
            } else if (arg[1] == 't') { // allow -tTEST
                runSingle = arg.substr(2);
            }
        } else {
            int i = arg.find("=");
            if ((0 < i) && (i < arg.size())) {
                // an ad hoc parameter
                std::string key = arg.substr(0,i);
                std::string val = arg.substr(i + 1);
                adhocMap.setStringParam(key,val);
            } else {
                // a config file name
                std::ifstream configFile(arg.c_str());
                assert(configFile.good());
                configMap.readParams(configFile);
            }
        }
    }
    configMap.mergeFrom(adhocMap);

    // set a default dictionary file location for use by tests that need a
    // small non-random sorted data set
    if (!configMap.isParamSet(paramDictionaryFileName)) {
        std::string dictFileName = "dictWords";
        configMap.setStringParam(paramDictionaryFileName,dictFileName);
    }

    if (verbose) {
        configMap.dumpParams(std::cout);
    }
}

TestSuite * TestBase::releaseTestSuite

(

)

[inherited]

Definition at line 157 of file TestBase.cpp.

References TestBase::TestCaseGroup::addAllToTestSuite(), TestBase::defaultTests, TestBase::extraTests, TestBase::TestCaseGroup::findTest(), TestBase::pTestObj, TestBase::pTestSuite, TestBase::runAll, TestBase::runSingle, and TestBase::testName.

{
    assert(pTestObj);
    assert(pTestObj.use_count() > 1);

    // release self-reference now that all test cases have been registered
    pTestObj.reset();

    TestSuite* pTestSuite = BOOST_TEST_SUITE(testName.c_str());

    if (runSingle.size()) {
        test_unit *p =  defaultTests.findTest(runSingle);
        if (!p) {
            p = extraTests.findTest(runSingle);
        }
        if (!p) {
            std::cerr << "test " << runSingle << " not found\n";
            exit(2);
        }
        pTestSuite->add(p);
    } else {
        defaultTests.addAllToTestSuite(pTestSuite);
        if (runAll) {
            extraTests.addAllToTestSuite(pTestSuite);
        }
    }
    return pTestSuite;
}

void TestBase::beforeTestCase

(

std::string

testCaseName

)

[inherited]

Definition at line 214 of file TestBase.cpp.

References TestBase::configMap, TraceSource::initTraceSource(), AutoBacktrace::install(), TestBase::notifyTrace(), AutoBacktrace::setOutputStream(), AutoBacktrace::setTraceTarget(), TestBase::testName, and TRACE_INFO.

{
    notifyTrace(testName,TRACE_INFO,"ENTER:  " + testCaseName);

    // Install the AutoBacktrace signal handler now, after
    // boost::execution_monitor::catch_signals() has installed its own, so that
    // on SIGABRT AutoBacktrace goes first, prints the backtrace, then chains
    // to boost, which handles the error.
    AutoBacktrace::setOutputStream();
    AutoBacktrace::setTraceTarget(shared_from_this());
    AutoBacktrace::install();
    configMap.initTraceSource(shared_from_this(), "testConfig");
}

void TestBase::afterTestCase

(

std::string

testCaseName

)

[inherited]

Definition at line 228 of file TestBase.cpp.

References TestBase::configMap, TraceSource::disableTracing(), TestBase::notifyTrace(), AutoBacktrace::setTraceTarget(), TestBase::testName, and TRACE_INFO.

{
    AutoBacktrace::setTraceTarget();
    configMap.disableTracing();
    notifyTrace(testName,TRACE_INFO,"LEAVE:  " + testCaseName);
}

void TestBase::notifyTrace	(	std::string	source,
		TraceLevel	level,
		std::string	message
	)			[virtual, inherited]

Receives notification when a trace event occurs.

Parameters:

	source	the facility from which the message originated
	level	the trace event severity level
	message	the text of the message

Implements TraceTarget.

Definition at line 243 of file TestBase.cpp.

References TestBase::traceFile, TestBase::traceMutex, TestBase::traceStdout, and TestBase::traceStream.

Referenced by TestBase::afterTestCase(), and TestBase::beforeTestCase().

{
    if (traceFile || traceStdout) {
        StrictMutexGuard traceMutexGuard(traceMutex);
        if (traceFile) {
            traceStream << "[" << source << "] " << message << std::endl;
            traceStream.flush();
        }
        if (traceStdout) {
            std::cout << "[" << source << "] " << message << std::endl;
            std::cout.flush();
        }
    }
}

TraceLevel TestBase::getSourceTraceLevel

(

std::string

source

)

[virtual, inherited]

Gets the level at which a particular source should be traced.

Parameters:

source

name of source to be traced

Returns:

minimum severity level which should be traced

Implements TraceTarget.

Definition at line 258 of file TestBase.cpp.

References TestBase::traceLevel.

Referenced by LbmExecStreamTestBase::generateBitmaps().

{
    return traceLevel;
}

---

Member Data Documentation

SharedCache BTreeTxnTest::pCache [private]

Definition at line 78 of file BTreeTxnTest.cpp.

Referenced by createTree(), deleteTxn(), insertTxn(), testCaseSetUp(), testCaseTearDown(), testTxns(), and threadInit().

SharedDatabase BTreeTxnTest::pDatabase [private]

Definition at line 79 of file BTreeTxnTest.cpp.

Referenced by createTree(), deleteTxn(), insertTxn(), testCaseSetUp(), testCaseTearDown(), testCheckpoint(), testThreadedOp(), testTxns(), and threadInit().

BTreeDescriptor BTreeTxnTest::treeDescriptor [private]

Definition at line 81 of file BTreeTxnTest.cpp.

Referenced by createTree(), testTxns(), threadInit(), and verifyTree().

boost::thread_specific_ptr<TestThreadData> BTreeTxnTest::pTestThreadData [private]

Definition at line 83 of file BTreeTxnTest.cpp.

Referenced by deleteTxn(), generateRandomNumber(), getKeyData(), getReader(), getWriter(), insertTxn(), threadInit(), and threadTerminate().

PageId BTreeTxnTest::rootPageId [private]

Definition at line 84 of file BTreeTxnTest.cpp.

Referenced by createTree(), and testCaseSetUp().

bool BTreeTxnTest::testRollback [private]

Definition at line 86 of file BTreeTxnTest.cpp.

Referenced by BTreeTxnTest(), and endTxn().

uint BTreeTxnTest::iKeyMax [private]

Definition at line 87 of file BTreeTxnTest.cpp.

Referenced by BTreeTxnTest(), deleteTxn(), insertTxn(), and scanTxn().

uint BTreeTxnTest::nInsertsPerTxn [private]

Definition at line 88 of file BTreeTxnTest.cpp.

Referenced by BTreeTxnTest(), and insertTxn().

uint BTreeTxnTest::nDeletesPerTxn [private]

Definition at line 89 of file BTreeTxnTest.cpp.

Referenced by BTreeTxnTest(), and deleteTxn().

uint BTreeTxnTest::nKeysPerScan [private]

Definition at line 90 of file BTreeTxnTest.cpp.

Referenced by BTreeTxnTest(), and scanTxn().

uint BTreeTxnTest::nSecondsBetweenCheckpoints [private]

Definition at line 92 of file BTreeTxnTest.cpp.

Referenced by BTreeTxnTest(), and testCheckpoint().

uint ThreadedTestBase::nSeconds [protected, inherited]

Duration of multi-threaded test.

Definition at line 65 of file ThreadedTestBase.h.

Referenced by BTreeTxnTest(), PagingTestBase::PagingTestBase(), ThreadedTestBase::runThreadedTestCase(), PagingTestBase::testCacheResize(), and ThreadedTestBase::ThreadedTestBase().

std::vector<int> ThreadedTestBase::threadCounts [protected, inherited]

Number of threads to run for each type of operation.

Definition at line 70 of file ThreadedTestBase.h.

Referenced by BTreeTxnTest(), CacheTest::CacheTest(), SegmentTestBase::openStorage(), PagingTestBase::PagingTestBase(), ThreadedTestBase::runThreadedTestCase(), and SegmentTestBase::SegmentTestBase().

TestSuite* TestBase::pTestSuite [protected, inherited]

Boost test suite.

Definition at line 59 of file TestBase.h.

Referenced by TestBase::releaseTestSuite().

boost::shared_ptr<TestBase> TestBase::pTestObj [protected, inherited]

Definition at line 61 of file TestBase.h.

Referenced by TestBase::releaseTestSuite(), and TestBase::TestBase().

std::ofstream TestBase::traceStream [protected, inherited]

Output file stream for tracing.

Definition at line 66 of file TestBase.h.

Referenced by TestBase::notifyTrace(), TestBase::TestBase(), and TestBase::~TestBase().

StrictMutex TestBase::traceMutex [protected, inherited]

Protects traceStream.

Definition at line 71 of file TestBase.h.

Referenced by TestBase::notifyTrace().

std::string TestBase::testName [protected, inherited]

Name of test.

Definition at line 76 of file TestBase.h.

Referenced by TestBase::afterTestCase(), TestBase::beforeTestCase(), TestBase::releaseTestSuite(), TestBase::TestBase(), LhxHashTableTest::testInsert1Ka(), and LhxHashTableTest::testInsert1Kb().

TraceLevel TestBase::traceLevel [protected, inherited]

Level at which to trace test execution.

Definition at line 81 of file TestBase.h.

Referenced by TestBase::getSourceTraceLevel(), and TestBase::TestBase().

FileStatsTarget TestBase::statsTarget [protected, inherited]

Output for stats.

Definition at line 86 of file TestBase.h.

StatsTimer TestBase::statsTimer [protected, inherited]

Timer for stats collection.

Definition at line 91 of file TestBase.h.

Referenced by CacheTestBase::closeStorage(), CacheTestBase::openStorage(), testCaseSetUp(), testCaseTearDown(), and testTxns().

bool TestBase::traceStdout [protected, inherited]

Copy trace output to stdout.

Definition at line 99 of file TestBase.h.

Referenced by TestBase::notifyTrace(), and TestBase::TestBase().

bool TestBase::traceFile [protected, inherited]

Copy trace output to file.

Definition at line 104 of file TestBase.h.

Referenced by TestBase::notifyTrace(), and TestBase::TestBase().

bool TestBase::runAll [static, protected, inherited]

Run all test cases, including the extra tests.

(static, since set by readParams())

Definition at line 110 of file TestBase.h.

Referenced by TestBase::readParams(), and TestBase::releaseTestSuite().

std::string TestBase::runSingle [static, protected, inherited]

Run only the test case of this name.

(static, since set by readParams())

Definition at line 116 of file TestBase.h.

Referenced by TestBase::readParams(), and TestBase::releaseTestSuite().

TestCaseGroup TestBase::defaultTests [protected, inherited]

Definition at line 139 of file TestBase.h.

Referenced by TestBase::releaseTestSuite().

TestCaseGroup TestBase::extraTests [protected, inherited]

Definition at line 140 of file TestBase.h.

Referenced by TestBase::releaseTestSuite().

ParamName TestBase::paramTestSuiteName [static, inherited]

Definition at line 143 of file TestBase.h.

Referenced by TestBase::TestBase().

ParamName TestBase::paramTraceFileName [static, inherited]

Definition at line 144 of file TestBase.h.

Referenced by TestBase::TestBase().

ParamName TestBase::paramDictionaryFileName [static, inherited]

Definition at line 145 of file TestBase.h.

Referenced by TestBase::readParams(), SegStreamTest::testRead(), and SegStreamTest::testWrite().

ParamName TestBase::paramTraceLevel [static, inherited]

Definition at line 146 of file TestBase.h.

Referenced by TestBase::TestBase().

ParamName TestBase::paramStatsFileName [static, inherited]

Definition at line 147 of file TestBase.h.

ParamName TestBase::paramTraceStdout [static, inherited]

Definition at line 148 of file TestBase.h.

Referenced by TestBase::TestBase().

ParamName TestBase::paramDegreeOfParallelism [static, inherited]

Definition at line 149 of file TestBase.h.

Referenced by ParallelExecStreamSchedulerTest::ParallelExecStreamSchedulerTest().

ConfigMap TestBase::configMap [static, inherited]

Configuration parameters.

The reason this is static is so that no constructor parameters (which burden virtual bases) are needed.

Definition at line 155 of file TestBase.h.

Referenced by TestBase::afterTestCase(), TestBase::beforeTestCase(), BTreeTxnTest(), CacheTestBase::CacheTestBase(), BackupRestoreTest::createSnapshotData(), DatabaseTest::DatabaseTest(), TestOptionsTest::extra(), DatabaseTest::loadDatabase(), SparseBitmapTest::openStorage(), PagingTestBase::PagingTestBase(), ParallelExecStreamSchedulerTest::ParallelExecStreamSchedulerTest(), RandomAccessFileDeviceTest::RandomAccessFileDeviceTest(), TestBase::readParams(), SegStorageTestBase::SegStorageTestBase(), TestOptionsTest::test1(), TestOptionsTest::test2(), BackupRestoreTest::testBackupCleanup(), TestBase::TestBase(), testCaseSetUp(), testCheckpoint(), DatabaseTest::testCreateEmpty(), DatabaseTest::testForceTxns(), BackupRestoreTest::testHeaderBackupRestore(), SegPageEntryIterTest::testIter(), SegStreamTest::testRead(), testTxns(), SegStreamTest::testWrite(), ThreadedTestBase::ThreadedTestBase(), and TestBase::~TestBase().

---

The documentation for this class was generated from the following file:

• /home/pub/open/dev/fennel/test/BTreeTxnTest.cpp

---