RandomAccessFileDeviceTest Class Reference

Inheritance diagram for RandomAccessFileDeviceTest:

List of all members.

Public Member Functions
	RandomAccessFileDeviceTest ()
void	testPermanentNoDirect ()
void	testTemporary ()
void	testPermanentDirect ()
void	runModeTests ()
virtual void	testCaseTearDown ()
	Equivalent to JUnit TestCase.tearDown; this is called after each test case method is invoked.
TestSuite *	releaseTestSuite ()
void	beforeTestCase (std::string testCaseName)
void	afterTestCase (std::string testCaseName)
virtual void	testCaseSetUp ()
	Equivalent to JUnit TestCase.setUp; this is called before each test case method is invoked.
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	snooze (uint nSeconds)
Protected Attributes
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 Member Functions
void	openDevice (DeviceMode openMode, std::string devName)
void	closeDevice ()
void	testDeviceCreation ()
void	testGrow ()
void	testShrink ()
void	testLargeFile ()
void	testAsyncIO ()
void	testRetryAsyncIO ()
void	testAsyncIO (FileSize cbOffset, int n=5)
void	testAsyncIOImpl (int n, uint cbSector, PBuffer pBuf, PBuffer pBuf2, FileSize cbOffset=0)
Private Attributes
DeviceAccessSchedulerParams	schedParams
SharedRandomAccessDevice	pRandomAccessDevice
DeviceMode	baseMode
Static Private Attributes
static const uint	ZERO_SIZE
static const uint	HALF_SIZE
static const uint	FULL_SIZE
Classes
class	Binding
class	Listener

---

Detailed Description

Definition at line 40 of file RandomAccessFileDeviceTest.cpp.

---

Constructor & Destructor Documentation

RandomAccessFileDeviceTest::RandomAccessFileDeviceTest

(

)

[inline, explicit]

Definition at line 347 of file RandomAccessFileDeviceTest.cpp.

References TestBase::configMap, DeviceAccessSchedulerParams::readConfig(), schedParams, testLargeFile(), testPermanentDirect(), testPermanentNoDirect(), testRetryAsyncIO(), and testTemporary().

    {
        schedParams.readConfig(configMap);
        FENNEL_UNIT_TEST_CASE(RandomAccessFileDeviceTest,testPermanentNoDirect);
        FENNEL_UNIT_TEST_CASE(RandomAccessFileDeviceTest,testTemporary);
        FENNEL_UNIT_TEST_CASE(RandomAccessFileDeviceTest,testPermanentDirect);
        FENNEL_UNIT_TEST_CASE(RandomAccessFileDeviceTest,testRetryAsyncIO);

        // NOTE jvs 11-Feb-2006:  This is optional since it creates
        // a 5G file.  On operating systems with sparse-file support, it
        // doesn't actually take up that much disk space.
        FENNEL_EXTRA_UNIT_TEST_CASE(
            RandomAccessFileDeviceTest,testLargeFile);
    }

---

Member Function Documentation

void RandomAccessFileDeviceTest::openDevice	(	DeviceMode	openMode,
		std::string	devName
	)			[inline, private]

Definition at line 50 of file RandomAccessFileDeviceTest.cpp.

References DeviceMode::create, pRandomAccessDevice, and FileSystem::remove().

Referenced by testAsyncIOImpl(), testDeviceCreation(), testGrow(), and testShrink().

    {
        if (openMode.create) {
            FileSystem::remove(devName.c_str());
        }
        pRandomAccessDevice.reset(
            new RandomAccessFileDevice(devName,openMode));
    }

void RandomAccessFileDeviceTest::closeDevice

(

)

[inline, private]

Definition at line 59 of file RandomAccessFileDeviceTest.cpp.

References pRandomAccessDevice.

Referenced by testAsyncIOImpl(), testCaseTearDown(), testDeviceCreation(), testGrow(), and testShrink().

    {
        pRandomAccessDevice.reset();
    }

void RandomAccessFileDeviceTest::testDeviceCreation

(

)

[inline, private]

Definition at line 64 of file RandomAccessFileDeviceTest.cpp.

References baseMode, closeDevice(), DeviceMode::create, FileSystem::doesFileExist(), openDevice(), and DeviceMode::temporary.

Referenced by runModeTests().

    {
        const char *devName = "test.dat";
        DeviceMode openMode = baseMode;
        openMode.create = 1;
        openDevice(openMode,devName);
        closeDevice();
        if (openMode.temporary) {
            if (FileSystem::doesFileExist(devName)) {
                std::cerr << "temporary test.dat not deleted" << std::endl;
            }
        } else {
            openMode.create = 0;
            openDevice(openMode,devName);
            closeDevice();
        }
    }

void RandomAccessFileDeviceTest::testGrow

(

)

[inline, private]

Definition at line 82 of file RandomAccessFileDeviceTest.cpp.

References baseMode, closeDevice(), DeviceMode::create, FULL_SIZE, openDevice(), pRandomAccessDevice, DeviceMode::temporary, and ZERO_SIZE.

Referenced by runModeTests().

    {
        const char *devName = "grow.dat";
        DeviceMode openMode = baseMode;
        openMode.create = 1;
        openDevice(openMode,devName);
        BOOST_CHECK_EQUAL(ZERO_SIZE, pRandomAccessDevice->getSizeInBytes());
        pRandomAccessDevice->setSizeInBytes(FULL_SIZE);
        BOOST_CHECK_EQUAL(FULL_SIZE, pRandomAccessDevice->getSizeInBytes());
        closeDevice();
        if (openMode.temporary) {
            return;
        }
        openMode.create = 0;
        openDevice(openMode,devName);
        BOOST_CHECK_EQUAL(FULL_SIZE, pRandomAccessDevice->getSizeInBytes());
        closeDevice();
    }

void RandomAccessFileDeviceTest::testShrink

(

)

[inline, private]

Definition at line 101 of file RandomAccessFileDeviceTest.cpp.

References baseMode, closeDevice(), DeviceMode::create, FULL_SIZE, HALF_SIZE, openDevice(), pRandomAccessDevice, DeviceMode::temporary, and ZERO_SIZE.

Referenced by runModeTests().

    {
        const char *devName = "shrink.dat";
        DeviceMode openMode = baseMode;
        openMode.create = 1;
        openDevice(openMode,devName);
        BOOST_CHECK_EQUAL(ZERO_SIZE, pRandomAccessDevice->getSizeInBytes());
        pRandomAccessDevice->setSizeInBytes(FULL_SIZE);
        BOOST_CHECK_EQUAL(FULL_SIZE, pRandomAccessDevice->getSizeInBytes());
        closeDevice();
        if (openMode.temporary) {
            return;
        }
        openMode.create = 0;
        openDevice(openMode,devName);
        BOOST_CHECK_EQUAL(FULL_SIZE, pRandomAccessDevice->getSizeInBytes());
        pRandomAccessDevice->setSizeInBytes(HALF_SIZE);
        closeDevice();
        openDevice(openMode,devName);
        BOOST_CHECK_EQUAL(HALF_SIZE, pRandomAccessDevice->getSizeInBytes());
        closeDevice();
    }

void RandomAccessFileDeviceTest::testLargeFile

(

)

[inline, private]

Definition at line 124 of file RandomAccessFileDeviceTest.cpp.

References testAsyncIO().

Referenced by RandomAccessFileDeviceTest().

    {
        // Create a 5G file in order to test beyond 32-bit unsigned.
        FileSize cbOffset = 0x40000000; // 1G
        cbOffset *= 5;
        testAsyncIO(cbOffset);
    }

void RandomAccessFileDeviceTest::testAsyncIO

(

)

[inline, private]

Definition at line 210 of file RandomAccessFileDeviceTest.cpp.

Referenced by runModeTests(), testLargeFile(), and testRetryAsyncIO().

    {
        testAsyncIO(0);
    }

void RandomAccessFileDeviceTest::testRetryAsyncIO

(

)

[inline, private]

Definition at line 215 of file RandomAccessFileDeviceTest.cpp.

References testAsyncIO().

Referenced by RandomAccessFileDeviceTest().

    {
        testAsyncIO(0, 5000);
    }

void RandomAccessFileDeviceTest::testAsyncIO	(	FileSize	cbOffset,
		int	n = 5
	)			[inline, private]

Definition at line 220 of file RandomAccessFileDeviceTest.cpp.

References VMAllocator::allocate(), VMAllocator::deallocate(), HALF_SIZE, and testAsyncIOImpl().

    {
        uint cbSector = HALF_SIZE;
        VMAllocator allocator(cbSector*n);
        void *pBuf = allocator.allocate();
        void *pBuf2 = allocator.allocate();
        BOOST_REQUIRE(pBuf != NULL);
        try {
            testAsyncIOImpl(
                n, cbSector,
                reinterpret_cast<PBuffer>(pBuf),
                reinterpret_cast<PBuffer>(pBuf2),
                cbOffset);
        } catch (...) {
            allocator.deallocate(pBuf);
            allocator.deallocate(pBuf2);
            throw;
        }
        allocator.deallocate(pBuf);
        allocator.deallocate(pBuf2);
    }

void RandomAccessFileDeviceTest::testAsyncIOImpl	(	int	n,
		uint	cbSector,
		PBuffer	pBuf,
		PBuffer	pBuf2,
		FileSize	cbOffset = 0
	)			[inline, private]

Definition at line 242 of file RandomAccessFileDeviceTest.cpp.

References baseMode, RandomAccessRequest::bindingList, RandomAccessRequest::cbOffset, RandomAccessRequest::cbTransfer, closeDevice(), DeviceMode::create, RandomAccessFileDeviceTest::Listener::getMutex(), DeviceAccessScheduler::newScheduler(), RandomAccessFileDeviceTest::Listener::nSuccess, openDevice(), RandomAccessRequest::pDevice, pRandomAccessDevice, RandomAccessRequest::READ, DeviceAccessScheduler::registerDevice(), schedParams, DeviceAccessScheduler::schedule(), DeviceAccessScheduler::stop(), DeviceMode::temporary, RandomAccessRequest::type, DeviceAccessScheduler::unregisterDevice(), RandomAccessFileDeviceTest::Listener::waitForAll(), and RandomAccessRequest::WRITE.

Referenced by testAsyncIO().

    {
        DeviceAccessScheduler *pScheduler =
            DeviceAccessScheduler::newScheduler(schedParams);

        const char *devName = "async.dat";
        DeviceMode openMode = baseMode;
        openMode.create = 1;
        openDevice(openMode,devName);
        FileSize cbFile = cbOffset;
        cbFile += n*cbSector;
        pRandomAccessDevice->setSizeInBytes(cbFile);

        // close and re-open to get the actual file size
        if (!openMode.temporary) {
            closeDevice();
            openMode.create = 0;
            openDevice(openMode,devName);
            FileSize cbFileActual = pRandomAccessDevice->getSizeInBytes();
            BOOST_CHECK_EQUAL(cbFile, cbFileActual);
        }

        pScheduler->registerDevice(pRandomAccessDevice);
        std::string s = "Four score and seven years ago.";
        char const *writeBuf = s.c_str();
        uint cb = s.size();

        Listener writeListener(n);
        RandomAccessRequest writeRequest;
        writeRequest.pDevice = pRandomAccessDevice.get();
        writeRequest.cbOffset = cbOffset;
        writeRequest.cbTransfer=n*cbSector;
        writeRequest.type = RandomAccessRequest::WRITE;
        memcpy(pBuf, writeBuf, cb);
        for (int i = 0; i < n; i++) {
            Binding *pBinding = new Binding(
                writeListener,cbSector,PBuffer(pBuf));
            writeRequest.bindingList.push_back(*pBinding);
        }

        // LER-7110: take a redundant mutex on the listener around the request
        // to confirm that attempts to notify the listener don't deadlock in
        // the case where the async I/O queue is full
        StrictMutexGuard mutexGuard(writeListener.getMutex());
        pScheduler->schedule(writeRequest);
        mutexGuard.unlock();

        writeListener.waitForAll();
        BOOST_CHECK_EQUAL(n, writeListener.nSuccess);
        pRandomAccessDevice->flush();

        if (!openMode.temporary) {
            pScheduler->unregisterDevice(pRandomAccessDevice);
            closeDevice();
            openMode.create = 0;
            openDevice(openMode,devName);
            pScheduler->registerDevice(pRandomAccessDevice);
        }

        Listener readListener(n + 1);
        RandomAccessRequest readRequest;
        readRequest.pDevice = pRandomAccessDevice.get();
        readRequest.cbOffset = cbOffset;
        readRequest.cbTransfer = n*cbSector;
        readRequest.type = RandomAccessRequest::READ;
        for (int i = 0; i < n; i++) {
            Binding *pBinding = new Binding(
                readListener,cbSector,
                pBuf + i*cbSector);
            readRequest.bindingList.push_back(*pBinding);
        }

        // Test a simultaneous read on the same device which intersects
        // with the reads above; this simulates something like an online
        // backup reading into private buffers, aliasing the cache.
        RandomAccessRequest readRequest2;
        readRequest2.pDevice = pRandomAccessDevice.get();
        readRequest2.cbOffset = cbOffset;
        readRequest2.cbTransfer = cbSector;
        readRequest2.type = RandomAccessRequest::READ;
        Binding *pBinding = new Binding(
            readListener, cbSector, pBuf2);
        readRequest2.bindingList.push_back(*pBinding);

        pScheduler->schedule(readRequest);
        pScheduler->schedule(readRequest2);
        readListener.waitForAll();
        BOOST_CHECK_EQUAL(n + 1, readListener.nSuccess);
        for (int i = 0; i < n; i++) {
            std::string s2(reinterpret_cast<char *>(pBuf + i*cbSector),cb);
            BOOST_CHECK_EQUAL(s,s2);
        }
        std::string s3(reinterpret_cast<char *>(pBuf2),cb);
        BOOST_CHECK_EQUAL(s,s3);

        pScheduler->unregisterDevice(pRandomAccessDevice);
        closeDevice();

        pScheduler->stop();
        delete pScheduler;
    }

void RandomAccessFileDeviceTest::testPermanentNoDirect

(

)

[inline]

Definition at line 362 of file RandomAccessFileDeviceTest.cpp.

References baseMode, DeviceMode::load, and runModeTests().

Referenced by RandomAccessFileDeviceTest().

    {
        baseMode = DeviceMode::load;
        runModeTests();
    }

void RandomAccessFileDeviceTest::testTemporary

(

)

[inline]

Definition at line 368 of file RandomAccessFileDeviceTest.cpp.

References baseMode, DeviceMode::load, runModeTests(), and DeviceMode::temporary.

Referenced by RandomAccessFileDeviceTest().

    {
        baseMode = DeviceMode::load;
        baseMode.temporary = true;
        runModeTests();
    }

void RandomAccessFileDeviceTest::testPermanentDirect

(

)

[inline]

Definition at line 375 of file RandomAccessFileDeviceTest.cpp.

References baseMode, DeviceMode::direct, DeviceMode::load, and runModeTests().

Referenced by RandomAccessFileDeviceTest().

    {
        baseMode = DeviceMode::load;
        baseMode.direct = true;
        runModeTests();
    }

void RandomAccessFileDeviceTest::runModeTests

(

)

[inline]

Definition at line 382 of file RandomAccessFileDeviceTest.cpp.

References testAsyncIO(), testDeviceCreation(), testGrow(), and testShrink().

Referenced by testPermanentDirect(), testPermanentNoDirect(), and testTemporary().

    {
        testDeviceCreation();
        testGrow();
        testShrink();
        testAsyncIO();
    }

virtual void RandomAccessFileDeviceTest::testCaseTearDown

(

)

[inline, 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 390 of file RandomAccessFileDeviceTest.cpp.

References closeDevice().

    {
        closeDevice();
    }

void TestBase::snooze

(

uint

nSeconds

)

[protected, inherited]

Definition at line 263 of file TestBase.cpp.

Referenced by DatabaseTest::executeForceTxn(), ThreadedTestBase::runThreadedTestCase(), PagingTestBase::testCacheResize(), BTreeTxnTest::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::testCaseSetUp

(

)

[virtual, inherited]

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

Default is no-op.

Reimplemented in LbmEntryTest, LbmExecStreamTestBase, LbmLoadBitmapTest, LbmSearchTest, LbmSplicerExecStreamTest, LcsClusterAppendExecStreamTest, LcsClusterReplaceExecStreamTest, LcsMultiClusterAppendTest, LcsRowScanExecStreamTest, BTreeReadersTest, BTreeTest, BTreeTxnTest, ExecStreamGovernorTest, ExecStreamTestBase, ExecStreamUnitTestBase, ExternalSortExecStreamTest, LhxHashTableTest, LogicalTxnTest, and SnapshotSegmentTestBase.

Definition at line 235 of file TestBase.cpp.

Referenced by ExecStreamTestBase::testCaseSetUp().

{
}

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

const uint RandomAccessFileDeviceTest::ZERO_SIZE [static, private]

Definition at line 42 of file RandomAccessFileDeviceTest.cpp.

Referenced by testGrow(), and testShrink().

const uint RandomAccessFileDeviceTest::HALF_SIZE [static, private]

Definition at line 43 of file RandomAccessFileDeviceTest.cpp.

Referenced by testAsyncIO(), and testShrink().

const uint RandomAccessFileDeviceTest::FULL_SIZE [static, private]

Definition at line 44 of file RandomAccessFileDeviceTest.cpp.

Referenced by testGrow(), and testShrink().

DeviceAccessSchedulerParams RandomAccessFileDeviceTest::schedParams [private]

Definition at line 46 of file RandomAccessFileDeviceTest.cpp.

Referenced by RandomAccessFileDeviceTest(), and testAsyncIOImpl().

SharedRandomAccessDevice RandomAccessFileDeviceTest::pRandomAccessDevice [private]

Definition at line 47 of file RandomAccessFileDeviceTest.cpp.

Referenced by closeDevice(), openDevice(), testAsyncIOImpl(), testGrow(), and testShrink().

DeviceMode RandomAccessFileDeviceTest::baseMode [private]

Definition at line 48 of file RandomAccessFileDeviceTest.cpp.

Referenced by testAsyncIOImpl(), testDeviceCreation(), testGrow(), testPermanentDirect(), testPermanentNoDirect(), testShrink(), and testTemporary().

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(), BTreeTxnTest::testCaseSetUp(), BTreeTxnTest::testCaseTearDown(), and BTreeTxnTest::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::BTreeTxnTest(), CacheTestBase::CacheTestBase(), BackupRestoreTest::createSnapshotData(), DatabaseTest::DatabaseTest(), TestOptionsTest::extra(), DatabaseTest::loadDatabase(), SparseBitmapTest::openStorage(), PagingTestBase::PagingTestBase(), ParallelExecStreamSchedulerTest::ParallelExecStreamSchedulerTest(), RandomAccessFileDeviceTest(), TestBase::readParams(), SegStorageTestBase::SegStorageTestBase(), TestOptionsTest::test1(), TestOptionsTest::test2(), BackupRestoreTest::testBackupCleanup(), TestBase::TestBase(), BTreeTxnTest::testCaseSetUp(), BTreeTxnTest::testCheckpoint(), DatabaseTest::testCreateEmpty(), DatabaseTest::testForceTxns(), BackupRestoreTest::testHeaderBackupRestore(), SegPageEntryIterTest::testIter(), SegStreamTest::testRead(), BTreeTxnTest::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/RandomAccessFileDeviceTest.cpp

---