LbmEntryTest Class Reference

Testcase for LbmEntry class. More...

Inheritance diagram for LbmEntryTest:

List of all members.

Public Member Functions
	LbmEntryTest ()
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.
void	testRandom1 ()
void	testRandom2 ()
void	testRandom3 ()
void	testRandom4 ()
void	testRandom5 ()
void	testCombos ()
void	testldb35 ()
void	testler5920 ()
void	testZeroBytes ()
void	testMergeSingletonInFront1 ()
void	testMergeSingletonInFront2 ()
void	testMergeSingletonMidSegment1 ()
void	testMergeSingletonMidSegment2 ()
void	testMergeSingletonMidSegment3 ()
void	testMergeSingletonMidSegment4 ()
void	testMergeSingletonEndSegment ()
void	testMergeSingletonStartSegment1 ()
void	testMergeSingletonStartSegment2 ()
void	testMergeSingletonInBetweenSegment ()
void	testMergeSingletonSplitLeft1 ()
void	testMergeSingletonSplitLeft2 ()
void	testMergeSingletonSplitRight1 ()
void	testMergeSingletonSplitRight2 ()
void	testMergeSingletonSplitHalf ()
void	testMergeSingletonSplitLast ()
void	testMergeSingletonSplitMaxSegments ()
void	testMergeSingletonZeros1 ()
void	testMergeSingletonZeros2 ()
void	testMergeSingletonZeros3 ()
void	testMergeSingletonZeros4 ()
void	testMergeSingletonAfterSplit ()
void	testMergeSingletonCombine ()
void	testMergeSingletonMaxSeg ()
void	testMergeSingletonRandom1 ()
void	testMergeSingletonRandom2 ()
void	testMergeSingletonWithSingleton1 ()
void	testMergeSingletonWithSingleton2 ()
virtual void	openStorage (DeviceMode openMode)
virtual void	openSegmentStorage (DeviceMode openMode)
virtual void	openRandomSegment ()
SharedSegment	createLinearDeviceSegment (DeviceId deviceId, uint nPages)
void	closeLinearSegment ()
void	closeRandomSegment ()
void	closeVersionedRandomSegment ()
void	closeSnapshotRandomSegment ()
virtual void	closeStorage ()
Cache &	getCache ()
virtual SharedCache	newCache ()
SharedRandomAccessDevice	openDevice (std::string devName, DeviceMode openMode, uint nDevicePages, DeviceId deviceId)
void	closeDevice (DeviceId deviceId, SharedRandomAccessDevice &pDevice)
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 Types
enum	VictimPolicy { victimTwoQ, victimLRU, victimRandom }
	The available victim policy implementations. More...
Protected Member Functions
void	snooze (uint nSeconds)
Protected Attributes
SharedSegmentFactory	pSegmentFactory
SharedSegment	pLinearSegment
	Segment supporting linear page allocation.
SharedSegment	pRandomSegment
	(Optional) segment supporting random page allocation.
SharedSegment	pVersionedRandomSegment
	(Optional) segment supporting versioned random page allocation.
SharedSegment	pSnapshotRandomSegment
	(Optional) segment supporting snapshot random page allocation.
VictimPolicy	victimPolicy
	VictimPolicy to instantiate.
CacheParams	cacheParams
	Parameters for cache initialization.
SharedCache	pCache
	Cache instance being tested.
SharedRandomAccessDevice	pRandomAccessDevice
	The default cached device.
uint	nMemPages
	Size of cache in memory pages.
uint	nDiskPages
	Size of device in disk pages.
uint	cbPageFull
	Disk page size.
DeviceId	dataDeviceId
	Fixed ID to assign to data device.
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	testRandom (uint nUniqueKeys, uint nRows, uint scratchBufferSize)
void	testMergeEntry (std::vector< LcsRid > const &ridValues, VectorOfUint const &nRidsPerBitmap, uint scratchBufferSize)
	Main test routine for exercising mergeEntry.
void	newLbmEntry (std::vector< SharedLbmEntryInfo > &entryList, LcsRid startRid, SegPageLock &bufferLock)
PBuffer	allocateBuf (SegPageLock &bufferLock)
bool	compareExpected (LbmEntry &entry, std::vector< LcsRid > const &ridValues, uint &ridPos, bool testContains)
void	recurseCombos (uint curr, uint nEntries, VectorOfUint &eTypes)
void	generateBitmaps (EntryType etype, std::vector< LcsRid > &ridValues, VectorOfUint &nRidsPerBitmap)
void	generateSingleBitmaps (std::vector< LcsRid > &ridValues, VectorOfUint &nRidsPerBitmap, LcsRid startRid, uint nRids)
void	generateCompressedBitmaps (std::vector< LcsRid > &ridValues, VectorOfUint &nRidsPerBitmap, LcsRid startRid, uint nRids)
void	testMergeSingleton (uint scratchBufferSize, const std::vector< LcsRid > &ridValues, uint nSingletons, bool split)
	Main test routine for merging arbitrary singleton entries.
void	testMergeSingletonRandom (uint totalRids, uint ridRange)
Private Attributes
uint	bitmapColSize
StandardTypeDescriptorFactory	stdTypeFactory
TupleAttributeDescriptor	attrDesc_bitmap
TupleAttributeDescriptor	attrDesc_int64
TupleDescriptor	entryTupleDesc
uint	bufSize
uint	bufUsed
PBuffer	pBuf
TupleData	entryTuple

---

Detailed Description

Testcase for LbmEntry class.

Definition at line 60 of file LbmEntryTest.cpp.

---

Member Enumeration Documentation

enum CacheTestBase::VictimPolicy [protected, inherited]

The available victim policy implementations.

Enumerator:

victimTwoQ
victimLRU
victimRandom

Definition at line 44 of file CacheTestBase.h.

                      {
        victimTwoQ,
        victimLRU,
        victimRandom
    };

---

Constructor & Destructor Documentation

LbmEntryTest::LbmEntryTest

(

)

[inline, explicit]

Definition at line 127 of file LbmEntryTest.cpp.

References testCombos(), testldb35(), testler5920(), testMergeSingletonAfterSplit(), testMergeSingletonCombine(), testMergeSingletonEndSegment(), testMergeSingletonInBetweenSegment(), testMergeSingletonInFront1(), testMergeSingletonInFront2(), testMergeSingletonMaxSeg(), testMergeSingletonMidSegment1(), testMergeSingletonMidSegment2(), testMergeSingletonMidSegment3(), testMergeSingletonMidSegment4(), testMergeSingletonRandom1(), testMergeSingletonRandom2(), testMergeSingletonSplitHalf(), testMergeSingletonSplitLast(), testMergeSingletonSplitLeft1(), testMergeSingletonSplitLeft2(), testMergeSingletonSplitMaxSegments(), testMergeSingletonSplitRight1(), testMergeSingletonSplitRight2(), testMergeSingletonStartSegment1(), testMergeSingletonStartSegment2(), testMergeSingletonWithSingleton1(), testMergeSingletonWithSingleton2(), testMergeSingletonZeros1(), testMergeSingletonZeros2(), testMergeSingletonZeros3(), testMergeSingletonZeros4(), testRandom1(), testRandom2(), testRandom3(), testRandom4(), testRandom5(), and testZeroBytes().

    {
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testRandom1);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testRandom2);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testRandom3);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testRandom4);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testRandom5);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testCombos);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testldb35);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testler5920);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testZeroBytes);

        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonInFront1);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonInFront2);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonMidSegment1);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonMidSegment2);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonMidSegment3);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonMidSegment4);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonEndSegment);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonStartSegment1);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonStartSegment2);
        FENNEL_UNIT_TEST_CASE(
            LbmEntryTest, testMergeSingletonInBetweenSegment);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonSplitLeft1);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonSplitLeft2);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonSplitRight1);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonSplitRight2);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonSplitHalf);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonSplitLast);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonSplitMaxSegments);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonZeros1);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonZeros2);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonZeros3);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonZeros4);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonAfterSplit);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonCombine);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonMaxSeg);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonRandom1);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonRandom2);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonWithSingleton1);
        FENNEL_UNIT_TEST_CASE(LbmEntryTest, testMergeSingletonWithSingleton2);
    }

---

Member Function Documentation

void LbmEntryTest::testRandom	(	uint	nUniqueKeys,
		uint	nRows,
		uint	scratchBufferSize
	)			[private]

Definition at line 257 of file LbmEntryTest.cpp.

References testMergeEntry().

Referenced by testRandom1(), testRandom2(), testRandom3(), testRandom4(), and testRandom5().

{
    std::vector<LcsRid> ridValues;
    VectorOfUint nRidsPerBitmap;
    uint totalRids = nRows / nUniqueKeys;

    assert(scratchBufferSize >= 8);

    // generate random rid values, ensuring that they are unique, then
    // sort them
    std::hash_set<uint64_t> ridsGenerated;
    for (uint i = 0; i < totalRids;) {
        uint64_t rid = rand() % nRows;
        if (ridsGenerated.find(rid) == ridsGenerated.end()) {
            ridValues.push_back(LcsRid(rid));
            ridsGenerated.insert(rid);
            i++;
        }
    }
    // sort the rid values
    std::sort(ridValues.begin(), ridValues.end());
#if 0
    std::cout << "Rid Values After Sort" << std::endl;
    for (uint i = 0; i < ridValues.size(); i++) {
        std::cout << ridValues[i] << std::endl;
    }
#endif

    // generate random values that will determine how many rids
    // there are per bitmap
    uint ridCount = 0;
    while (ridCount < totalRids) {
        // divide by 4 so we'll later merge roughly 2-4 bitmaps per
        // entry
        uint nRids = rand() % (scratchBufferSize / 4) + 1;
        if (nRids + ridCount < totalRids) {
            nRidsPerBitmap.push_back(nRids);
            ridCount += nRids;
        } else {
            nRidsPerBitmap.push_back(totalRids - ridCount);
            break;
        }
    }

    testMergeEntry(ridValues, nRidsPerBitmap, scratchBufferSize);
}

void LbmEntryTest::testMergeEntry	(	std::vector< LcsRid > const &	ridValues,
		VectorOfUint const &	nRidsPerBitmap,
		uint	scratchBufferSize
	)			[private]

Main test routine for exercising mergeEntry.

Parameters:

	ridValues	vector of rid values to construct bitmaps for
	nRidsPerBitmap	vector of values indicating how many rids to include in each bitmap
	scratchBufferSize	size of scratch buffer used to construct bitmaps; size only indicates space to be used by bitmaps

Definition at line 305 of file LbmEntryTest.cpp.

References SegPageLock::accessSegment(), allocateBuf(), attrDesc_bitmap, attrDesc_int64, bitmapColSize, bufSize, bufUsed, compareExpected(), TupleData::compute(), entryTuple, entryTupleDesc, LbmEntry::getScratchBufferSize(), LbmEntry::init(), LbmEntry::mergeEntry(), StandardTypeDescriptorFactory::newDataType(), newLbmEntry(), NULL_PAGE_ID, CacheTestBase::pCache, SegmentAccessor::pSegment, SegStorageTestBase::pSegmentFactory, LbmEntry::setEntryTuple(), STANDARD_TYPE_INT_64, STANDARD_TYPE_VARBINARY, stdTypeFactory, and LbmEntry::toString().

Referenced by recurseCombos(), and testRandom().

{
    std::vector<SharedLbmEntryInfo> entryList;

    // bitmap entries will be created without a leading key, so the
    // first column is the startRid
    // initialize scratch accessor for scratch buffers used to
    // construct bitmaps
    SegmentAccessor scratchAccessor =
        pSegmentFactory->newScratchSegment(pCache, 10);
    bufSize = scratchAccessor.pSegment->getUsablePageSize();
    SegPageLock bufferLock;
    bufferLock.accessSegment(scratchAccessor);
    bufUsed = bufSize;

    bitmapColSize = scratchBufferSize;
    attrDesc_bitmap =
        TupleAttributeDescriptor(
            stdTypeFactory.newDataType(STANDARD_TYPE_VARBINARY),
            true, bitmapColSize);
    attrDesc_int64 =
        TupleAttributeDescriptor(
            stdTypeFactory.newDataType(STANDARD_TYPE_INT_64));

    entryTupleDesc.push_back(attrDesc_int64);
    entryTupleDesc.push_back(attrDesc_bitmap);
    entryTupleDesc.push_back(attrDesc_bitmap);
    entryTuple.compute(entryTupleDesc);
    entryTuple[1].pData = NULL;
    entryTuple[2].pData = NULL;

    // Generate bitmaps using the list of rid values. The number of rids
    // in each bitmap is based on the list of nRidsPerBitmap.

    uint totalRids = ridValues.size();
    uint nRidPos = 0;
    for (uint i = 0; i < totalRids;) {
        newLbmEntry(entryList, ridValues[i], bufferLock);
        i++;

        for (uint j = 1; i < totalRids && j < nRidsPerBitmap[nRidPos];
            i++, j++)
        {
            if (!entryList.back()->entry.setRID(ridValues[i])) {
                newLbmEntry(entryList, ridValues[i], bufferLock);
            }
        }
        nRidPos++;
    }

    // produce the tuples corresponding to each LbmEntry
    for (uint i = 0; i < entryList.size(); i++) {
        entryList[i]->entryTuple = entryList[i]->entry.produceEntryTuple();
    }

#if 0
    std::cout << "Generated Entries Before Merge" << std::endl;
    for (uint i = 0; i < entryList.size(); i++) {
        std::cout << LbmEntry::toString(entryList[i]->entryTuple, true)
            << std::endl;
    }
#endif

    // merge the entries constructed
    uint ridPos = 0;

    PBuffer mergeBuf = allocateBuf(bufferLock);
    LbmEntry mEntry;
    mEntry.init(
        mergeBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    mEntry.setEntryTuple(entryList[0]->entryTuple);
    for (uint i = 1; i < entryList.size(); i++) {
        if (mEntry.mergeEntry(entryList[i]->entryTuple)) {
            continue;
        }
        // not able to merge, so need to produce entry and compare against
        // expected rids before starting to merge on the next entry
        bool rc = compareExpected(mEntry, ridValues, ridPos, true);
        BOOST_REQUIRE(rc);
        mEntry.setEntryTuple(entryList[i]->entryTuple);
    }
    // if this is the last remaining entry, compare it against
    // expected rid values
    if (ridPos < totalRids) {
        bool rc = compareExpected(mEntry, ridValues, ridPos, true);
        BOOST_REQUIRE(rc);
    }

    BOOST_REQUIRE(ridPos == totalRids);

    scratchAccessor.pSegment->deallocatePageRange(NULL_PAGE_ID, NULL_PAGE_ID);
}

void LbmEntryTest::newLbmEntry	(	std::vector< SharedLbmEntryInfo > &	entryList,
		LcsRid	startRid,
		SegPageLock &	bufferLock
	)			[private]

Definition at line 401 of file LbmEntryTest.cpp.

References allocateBuf(), bitmapColSize, entryTuple, entryTupleDesc, and LbmEntry::getScratchBufferSize().

Referenced by testMergeEntry().

{
    SharedLbmEntryInfo pListElement = SharedLbmEntryInfo(new LbmEntryInfo());

    pListElement->pBuf = allocateBuf(bufferLock);
    pListElement->entry.init(
        pListElement->pBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    entryList.push_back(pListElement);
    entryTuple[0].pData = (PConstBuffer) &startRid;
    entryList.back()->entry.setEntryTuple(entryTuple);
}

PBuffer LbmEntryTest::allocateBuf

(

SegPageLock &

bufferLock

)

[private]

Definition at line 416 of file LbmEntryTest.cpp.

References SegPageLock::allocatePage(), bitmapColSize, bufSize, bufUsed, SegPageLock::getPage(), LbmEntry::getScratchBufferSize(), CachePage::getWritableData(), pBuf, and SegPageLock::unlock().

Referenced by newLbmEntry(), testldb35(), testler5920(), testMergeEntry(), and testZeroBytes().

{
    // allocate a new scratch page if not enough space is left on
    // the current
    uint scratchBufSize = LbmEntry::getScratchBufferSize(bitmapColSize);
    if (bufUsed + scratchBufSize > bufSize) {
        bufferLock.allocatePage();
        pBuf = bufferLock.getPage().getWritableData();
        bufferLock.unlock();
        bufUsed = 0;
    }
    PBuffer retBuf = pBuf + bufUsed;
    bufUsed += scratchBufSize;
    return retBuf;
}

bool LbmEntryTest::compareExpected	(	LbmEntry &	entry,
		std::vector< LcsRid > const &	ridValues,
		uint &	ridPos,
		bool	testContains
	)			[private]

Definition at line 432 of file LbmEntryTest.cpp.

References LbmEntry::containsRid(), LbmEntry::generateRIDs(), LbmEntry::getRowCount(), LbmEntry::produceEntryTuple(), LbmSegment::roundToByteBoundary(), and LbmEntry::toString().

Referenced by testldb35(), testler5920(), testMergeEntry(), testMergeSingleton(), and testZeroBytes().

{
    TupleData const &generatedTuple = generatedEntry.produceEntryTuple();
    std::vector<LcsRid> actualRids;
    LbmEntry::generateRIDs(generatedTuple, actualRids);

    LcsRid endRid;
    uint rowCount = generatedEntry.getRowCount();
    if (rowCount == 1) {
        // singleton
        endRid = expectedRids[ridPos] + 1;
    } else {
        endRid =
            LbmSegment::roundToByteBoundary(expectedRids[ridPos]) + rowCount;
    }

    uint i;
    for (i = 0;
        ridPos < expectedRids.size() && expectedRids[ridPos] < endRid &&
            i < actualRids.size();
        i++, ridPos++)
    {
        if (expectedRids[ridPos] != actualRids[i]) {
            break;
        }
        // the two if blocks below are redundant but are there to test the
        // containsRid() method; the first tests the positive case and the
        // second the negative
        if (!generatedEntry.containsRid(expectedRids[ridPos])) {
            std::cout << "Positive containsRid check failed on rid = " <<
                expectedRids[ridPos] << std::endl;
            return false;
        }
        // search for the rids in between the current and next; these should
        // not be set in the entry
        if (testContains) {
            if (ridPos + 1 < expectedRids.size()) {
                for (LcsRid nextRid = expectedRids[ridPos] + 1;
                    nextRid < expectedRids[ridPos + 1]; nextRid++)
                {
                    if (generatedEntry.containsRid(nextRid)) {
                        std::cout << "Negative containsRid check failed" <<
                           " on rid = " << nextRid << std::endl;
                        return false;
                    }
                }
            }
        }
    }
#if 0
    std::cout << "Generated Entry:" << LbmEntry::toString(generatedTuple, true)
        << std::endl;
#endif
    if (i < actualRids.size()) {
        std::cout << "Mismatch in rid.  Actual = " << actualRids[i] <<
            ", Expected = " << expectedRids[ridPos] << std::endl;
        return false;
    }
    return true;
}

void LbmEntryTest::recurseCombos	(	uint	curr,
		uint	nEntries,
		VectorOfUint &	eTypes
	)			[private]

Definition at line 924 of file LbmEntryTest.cpp.

References entryTuple, entryTupleDesc, generateBitmaps(), and testMergeEntry().

Referenced by testCombos().

{
    std::vector<LcsRid> ridValues;
    VectorOfUint nRidsPerBitmap;

    uint nETypes = (curr == 0) ? 3 : 9;
    for (uint i = 0; i < nETypes; i++) {
        eTypes[curr] = i;
        if (curr < nEntries - 1) {
            recurseCombos(curr + 1, nEntries, eTypes);
        } else {
            // generate the "nEntries" bitmaps
            for (uint n = 0; n < nEntries; n++) {
                generateBitmaps(
                    EntryType(eTypes[n]), ridValues, nRidsPerBitmap);
            }

            // generate the last entry
            ridValues.push_back(ridValues.back() + 16);
            nRidsPerBitmap.push_back(1);

            // merge them
            testMergeEntry(ridValues, nRidsPerBitmap, nEntries * 24);

            ridValues.clear();
            nRidsPerBitmap.clear();
            entryTupleDesc.clear();
            entryTuple.clear();
        }
    }
}

void LbmEntryTest::generateBitmaps	(	EntryType	etype,
		std::vector< LcsRid > &	ridValues,
		VectorOfUint &	nRidsPerBitmap
	)			[private]

Definition at line 957 of file LbmEntryTest.cpp.

References CMP_ADJ, CMP_NADJ, CMP_OVLP, generateCompressedBitmaps(), generateSingleBitmaps(), LbmSegment::LbmOneByteSize, SBM_ADJ, SBM_NADJ, SBM_OVLP, SGT_ADJ, SGT_NADJ, and SGT_OVLP.

Referenced by recurseCombos().

{
    LcsRid prev;

    if (ridValues.size() == 0) {
        prev = LcsRid(1);
    } else {
        prev = ridValues.back();
    }

    switch (etype) {
    case SBM_ADJ:
        generateSingleBitmaps(
            ridValues, nRidsPerBitmap, prev + LbmSegment::LbmOneByteSize, 4);
        break;
    case SBM_NADJ:
        generateSingleBitmaps(
            ridValues, nRidsPerBitmap, prev + LbmSegment::LbmOneByteSize*2, 4);
        break;
    case SBM_OVLP:
        generateSingleBitmaps(ridValues, nRidsPerBitmap, prev + 2, 4);
        break;
    case SGT_ADJ:
        generateSingleBitmaps(
            ridValues, nRidsPerBitmap, prev + LbmSegment::LbmOneByteSize, 1);
        break;
    case SGT_NADJ:
        generateSingleBitmaps(
            ridValues, nRidsPerBitmap, prev + LbmSegment::LbmOneByteSize*2, 1);
        break;
    case SGT_OVLP:
        generateSingleBitmaps(ridValues, nRidsPerBitmap, prev + 2, 1);
        break;
    case CMP_ADJ:
        generateCompressedBitmaps(
            ridValues, nRidsPerBitmap, prev + LbmSegment::LbmOneByteSize, 10);
        break;
    case CMP_NADJ:
        generateCompressedBitmaps(
            ridValues, nRidsPerBitmap, prev + LbmSegment::LbmOneByteSize*2, 10);
        break;
    case CMP_OVLP:
        generateCompressedBitmaps(ridValues, nRidsPerBitmap, prev + 2, 10);
        break;
    }
}

void LbmEntryTest::generateSingleBitmaps	(	std::vector< LcsRid > &	ridValues,
		VectorOfUint &	nRidsPerBitmap,
		LcsRid	startRid,
		uint	nRids
	)			[private]

Definition at line 1006 of file LbmEntryTest.cpp.

References LbmSegment::LbmOneByteSize.

Referenced by generateBitmaps().

{
    for (uint i = 0;  i < nRids; i++) {
        ridValues.push_back(startRid);
        startRid += LbmSegment::LbmOneByteSize;
    }
    nRidsPerBitmap.push_back(nRids);
}

void LbmEntryTest::generateCompressedBitmaps	(	std::vector< LcsRid > &	ridValues,
		VectorOfUint &	nRidsPerBitmap,
		LcsRid	startRid,
		uint	nRids
	)			[private]

Definition at line 1017 of file LbmEntryTest.cpp.

References LbmSegment::LbmOneByteSize.

Referenced by generateBitmaps().

{
    for (uint i = 0; i < nRids; i++) {
        ridValues.push_back(startRid);
        startRid += LbmSegment::LbmOneByteSize*2;
    }
    nRidsPerBitmap.push_back(nRids);
}

void LbmEntryTest::testMergeSingleton	(	uint	scratchBufferSize,
		const std::vector< LcsRid > &	ridValues,
		uint	nSingletons,
		bool	split
	)			[private]

Main test routine for merging arbitrary singleton entries.

Parameters:

	scratchBufferSize	size of scratch buffer used to merge entry
	ridValues	initial rid values followed by the singleton rids that will be merged
	nSingletons	number of singleton entries to be merged
	split	true if splits are allowed during merges

Definition at line 1028 of file LbmEntryTest.cpp.

References attrDesc_bitmap, attrDesc_int64, bitmapColSize, compareExpected(), TupleData::compute(), entryTuple, entryTupleDesc, FixedBuffer, LbmEntry::init(), LbmEntry::mergeEntry(), StandardTypeDescriptorFactory::newDataType(), LbmEntry::setEntryTuple(), LbmEntry::setRID(), STANDARD_TYPE_INT_64, STANDARD_TYPE_VARBINARY, and stdTypeFactory.

Referenced by testMergeSingletonAfterSplit(), testMergeSingletonCombine(), testMergeSingletonEndSegment(), testMergeSingletonInBetweenSegment(), testMergeSingletonInFront1(), testMergeSingletonInFront2(), testMergeSingletonMaxSeg(), testMergeSingletonMidSegment1(), testMergeSingletonMidSegment2(), testMergeSingletonMidSegment3(), testMergeSingletonMidSegment4(), testMergeSingletonRandom(), testMergeSingletonSplitHalf(), testMergeSingletonSplitLast(), testMergeSingletonSplitLeft1(), testMergeSingletonSplitLeft2(), testMergeSingletonSplitMaxSegments(), testMergeSingletonSplitRight1(), testMergeSingletonSplitRight2(), testMergeSingletonStartSegment1(), testMergeSingletonStartSegment2(), testMergeSingletonWithSingleton1(), testMergeSingletonWithSingleton2(), testMergeSingletonZeros1(), testMergeSingletonZeros2(), testMergeSingletonZeros3(), and testMergeSingletonZeros4().

{
    // bitmap entries will be created without a leading key, so the
    // first column is the startRid

    bitmapColSize = scratchBufferSize;
    attrDesc_bitmap =
        TupleAttributeDescriptor(
            stdTypeFactory.newDataType(STANDARD_TYPE_VARBINARY),
            true, bitmapColSize);
    attrDesc_int64 =
        TupleAttributeDescriptor(
            stdTypeFactory.newDataType(STANDARD_TYPE_INT_64));

    entryTupleDesc.push_back(attrDesc_int64);
    entryTupleDesc.push_back(attrDesc_bitmap);
    entryTupleDesc.push_back(attrDesc_bitmap);
    entryTuple.compute(entryTupleDesc);
    entryTuple[1].pData = NULL;
    entryTuple[2].pData = NULL;

    // generate the entry that the singleton will splice into
    LbmEntry lbmEntry;
    boost::scoped_array<FixedBuffer> buf, buf2;
    buf.reset(new FixedBuffer[scratchBufferSize]);
    buf2.reset(new FixedBuffer[scratchBufferSize]);
    lbmEntry.init(buf.get(), buf2.get(), scratchBufferSize, entryTupleDesc);
    entryTuple[0].pData = (PConstBuffer) &(ridValues[0]);
    lbmEntry.setEntryTuple(entryTuple);

    uint totalRids = ridValues.size();
    for (uint i = 1; i < totalRids - nSingletons; i++) {
        bool rc = lbmEntry.setRID(ridValues[i]);
        // make sure there is enough space to fit the initial set of rids
        BOOST_REQUIRE(rc);
    }

    std::vector<LcsRid> sortedRids;
    sortedRids.assign(ridValues.begin(), ridValues.end());
    std::sort(sortedRids.begin(), sortedRids.end());
#if 0
    std::cout << "Sorted Rid Values" << std::endl;
    for (uint i = 0; i < sortedRids.size(); i++) {
        std::cout << sortedRids[i] << std::endl;
    }
#endif

    // merge in the singletons and compare against the sorted original list
    // as entries fill up
    uint ridPos = 0;
    bool splitOccurred = false;
    for (uint i = 0; i < nSingletons; i++) {
        entryTuple[0].pData =
            (PConstBuffer) &(ridValues[totalRids - nSingletons + i]);
        entryTuple[1].pData = NULL;
        entryTuple[1].cbData = 0;
        entryTuple[2].pData = NULL;
        entryTuple[1].cbData = 0;
        if (!lbmEntry.mergeEntry(entryTuple)) {
            BOOST_REQUIRE(split);
            bool rc = compareExpected(lbmEntry, sortedRids, ridPos, true);
            BOOST_REQUIRE(rc);
            lbmEntry.setEntryTuple(entryTuple);
            splitOccurred = true;
        }
    }

    // compare the rids in the last entry
    if (ridPos < totalRids) {
        bool rc = compareExpected(lbmEntry, sortedRids, ridPos, true);
        BOOST_REQUIRE(rc);
    }

    BOOST_REQUIRE(ridPos == totalRids);

    BOOST_REQUIRE(!(split && !splitOccurred));
}

void LbmEntryTest::testMergeSingletonRandom	(	uint	totalRids,
		uint	ridRange
	)			[private]

Definition at line 1510 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by testMergeSingletonRandom1(), and testMergeSingletonRandom2().

{
    std::vector<LcsRid> ridValues;

    // generate random rid values, ensuring that they are unique
    LcsRid rid = LcsRid(rand() % ridRange);
    ridValues.push_back(rid);
    for (uint i = 1; i < totalRids;) {
        rid = LcsRid(rand() % ridRange);
        uint j;
        for (j = 0; j < i; j++) {
            if (rid == ridValues[j]) {
                break;
            }
        }
        if (j >= i) {
            ridValues.push_back(rid);
            i++;
            continue;
        }
    }

#if 0
    std::cout << "Original Rid Values" << std::endl;
    for (uint i = 0; i < ridValues.size(); i++) {
        std::cout << ridValues[i] << std::endl;
    }
#endif

    // the first rid becomes the initial entry and the rest are the singleton
    // rids
    uint scratchBufferSize = totalRids * 5 + 8;
    testMergeSingleton(scratchBufferSize, ridValues, totalRids - 1, false);
}

void LbmEntryTest::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 1576 of file LbmEntryTest.cpp.

References DeviceMode::createNew, and SegStorageTestBase::openStorage().

{
    openStorage(DeviceMode::createNew);
}

void LbmEntryTest::testCaseTearDown

(

)

[virtual]

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

Default is no-op.

Reimplemented from CacheTestBase.

Definition at line 1581 of file LbmEntryTest.cpp.

References entryTupleDesc, and CacheTestBase::testCaseTearDown().

{
    SegStorageTestBase::testCaseTearDown();
    entryTupleDesc.clear();
}

void LbmEntryTest::testRandom1

(

)

Definition at line 212 of file LbmEntryTest.cpp.

References testRandom().

Referenced by LbmEntryTest().

{
    uint nUniqueKeys = 10;
    uint nRows = 1000;
    uint scratchBufferSize = 40;

    testRandom(nUniqueKeys, nRows, scratchBufferSize);
}

void LbmEntryTest::testRandom2

(

)

Definition at line 221 of file LbmEntryTest.cpp.

References testRandom().

Referenced by LbmEntryTest().

{
    uint nUniqueKeys = 30;
    uint nRows = 2000;
    uint scratchBufferSize = 50;

    testRandom(nUniqueKeys, nRows, scratchBufferSize);
}

void LbmEntryTest::testRandom3

(

)

Definition at line 230 of file LbmEntryTest.cpp.

References testRandom().

Referenced by LbmEntryTest().

{
    uint nUniqueKeys = 25;
    uint nRows = 1500;
    uint scratchBufferSize = 30;

    testRandom(nUniqueKeys, nRows, scratchBufferSize);
}

void LbmEntryTest::testRandom4

(

)

Definition at line 239 of file LbmEntryTest.cpp.

References testRandom().

Referenced by LbmEntryTest().

{
    uint nUniqueKeys = 20;
    uint nRows = 2500;
    uint scratchBufferSize = 35;

    testRandom(nUniqueKeys, nRows, scratchBufferSize);
}

void LbmEntryTest::testRandom5

(

)

Definition at line 248 of file LbmEntryTest.cpp.

References testRandom().

Referenced by LbmEntryTest().

{
    uint nUniqueKeys = 15;
    uint nRows = 3000;
    uint scratchBufferSize = 45;

    testRandom(nUniqueKeys, nRows, scratchBufferSize);
}

void LbmEntryTest::testCombos

(

)

Definition at line 913 of file LbmEntryTest.cpp.

References recurseCombos().

Referenced by LbmEntryTest().

{
    uint nEntries = 5;
    VectorOfUint eTypes;

    for (uint i = 0; i < nEntries; i++) {
        eTypes.push_back(0);
    }
    recurseCombos(0, nEntries, eTypes);
}

void LbmEntryTest::testldb35

(

)

Definition at line 495 of file LbmEntryTest.cpp.

References SegPageLock::accessSegment(), allocateBuf(), attrDesc_bitmap, attrDesc_int64, bitmapColSize, bufSize, bufUsed, compareExpected(), TupleData::compute(), entryTuple, entryTupleDesc, LbmEntry::getScratchBufferSize(), LbmEntry::init(), LbmSegment::LbmOneByteSize, LbmEntry::mergeEntry(), StandardTypeDescriptorFactory::newDataType(), NULL_PAGE_ID, opaqueToInt(), CacheTestBase::pCache, SegmentAccessor::pSegment, SegStorageTestBase::pSegmentFactory, LbmSegment::roundToByteBoundary(), LbmEntry::setEntryTuple(), STANDARD_TYPE_INT_64, STANDARD_TYPE_VARBINARY, and stdTypeFactory.

Referenced by LbmEntryTest().

{
    std::vector<SharedLbmEntryInfo> entryList;
    std::vector<LcsRid> ridValues;

    // bitmap entries will be created without a leading key, so the
    // first column is the startRid
    // initialize scratch accessor for scratch buffers used to
    // construct bitmaps
    SegmentAccessor scratchAccessor =
        pSegmentFactory->newScratchSegment(pCache, 10);
    bufSize = scratchAccessor.pSegment->getUsablePageSize();
    SegPageLock bufferLock;
    bufferLock.accessSegment(scratchAccessor);
    bufUsed = bufSize;

    bitmapColSize = 16;
    attrDesc_bitmap =
        TupleAttributeDescriptor(
            stdTypeFactory.newDataType(STANDARD_TYPE_VARBINARY),
            true, bitmapColSize);
    attrDesc_int64 =
        TupleAttributeDescriptor(
            stdTypeFactory.newDataType(STANDARD_TYPE_INT_64));

    entryTupleDesc.push_back(attrDesc_int64);
    entryTupleDesc.push_back(attrDesc_bitmap);
    entryTupleDesc.push_back(attrDesc_bitmap);
    entryTuple.compute(entryTupleDesc);

    SharedLbmEntryInfo pListElement = SharedLbmEntryInfo(new LbmEntryInfo());

    // first entry -- single bitmap with rid 98601

    pListElement->pBuf = allocateBuf(bufferLock);
    pListElement->entry.init(
        pListElement->pBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    entryList.push_back(pListElement);
    LcsRid rid = LcsRid(98061);
    ridValues.push_back(rid);
    LcsRid roundedRid = LbmSegment::roundToByteBoundary(rid);
    entryTuple[0].pData = (PConstBuffer) &roundedRid;
    entryTuple[1].pData = NULL;
    uint8_t byte =
        (uint8_t) (1 << (opaqueToInt(rid) % LbmSegment::LbmOneByteSize));
    entryTuple[2].pData = &byte;
    entryTuple[2].cbData = 1;
    entryList.back()->entry.setEntryTuple(entryTuple);

    // second entry -- compressed bitmap with only rid 98070 set

    pListElement = SharedLbmEntryInfo(new LbmEntryInfo());
    pListElement->pBuf = allocateBuf(bufferLock);
    pListElement->entry.init(
        pListElement->pBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    entryList.push_back(pListElement);
    rid = LcsRid(98070);
    ridValues.push_back(rid);
    roundedRid = LbmSegment::roundToByteBoundary(rid);
    entryTuple[0].pData = (PConstBuffer) &roundedRid;
    uint8_t twoBytes[2];
    twoBytes[0] = 0xd;
    twoBytes[1] = 0xf0;
    entryTuple[1].pData = twoBytes;
    entryTuple[1].cbData = 2;
    byte = (uint8_t) (1 << (opaqueToInt(rid) % LbmSegment::LbmOneByteSize));
    entryTuple[2].pData = &byte;
    entryTuple[2].cbData = 1;
    entryList.back()->entry.setEntryTuple(entryTuple);

    // third entry -- compressed bitmap with only rid 99992 set

    pListElement = SharedLbmEntryInfo(new LbmEntryInfo());
    pListElement->pBuf = allocateBuf(bufferLock);
    pListElement->entry.init(
        pListElement->pBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    entryList.push_back(pListElement);
    rid = LcsRid(99992);
    ridValues.push_back(rid);
    roundedRid = LbmSegment::roundToByteBoundary(rid);
    entryTuple[0].pData = (PConstBuffer) &roundedRid;
    twoBytes[0] = 0xd;
    twoBytes[1] = 0x10;
    entryTuple[1].pData = twoBytes;
    entryTuple[1].cbData = 2;
    byte = (uint8_t) (1 << (opaqueToInt(rid) % LbmSegment::LbmOneByteSize));
    entryTuple[2].pData = &byte;
    entryTuple[2].cbData = 1;
    entryList.back()->entry.setEntryTuple(entryTuple);

    // fourth entry -- singleton with rid 100133

    pListElement = SharedLbmEntryInfo(new LbmEntryInfo());
    pListElement->pBuf = allocateBuf(bufferLock);
    pListElement->entry.init(
        pListElement->pBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    entryList.push_back(pListElement);
    rid = LcsRid(100133);
    ridValues.push_back(rid);
    entryTuple[0].pData = (PConstBuffer) &rid;
    entryTuple[1].pData = NULL;
    entryTuple[2].pData = NULL;
    entryList.back()->entry.setEntryTuple(entryTuple);

    // fifth entry -- singleton with rid 100792

    pListElement = SharedLbmEntryInfo(new LbmEntryInfo());
    pListElement->pBuf = allocateBuf(bufferLock);
    pListElement->entry.init(
        pListElement->pBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    entryList.push_back(pListElement);
    rid = LcsRid(100792);
    ridValues.push_back(rid);
    entryTuple[0].pData = (PConstBuffer) &rid;
    entryTuple[1].pData = NULL;
    entryTuple[2].pData = NULL;
    entryList.back()->entry.setEntryTuple(entryTuple);

    // produce the tuples corresponding to each LbmEntry
    for (uint i = 0; i < entryList.size(); i++) {
        entryList[i]->entryTuple = entryList[i]->entry.produceEntryTuple();
    }

    uint ridPos = 0;
    PBuffer mergeBuf = allocateBuf(bufferLock);
    LbmEntry mEntry;
    mEntry.init(
        mergeBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);

    mEntry.setEntryTuple(entryList[0]->entryTuple);
    for (uint i = 1; i < entryList.size(); i++) {
        if (mEntry.mergeEntry(entryList[i]->entryTuple)) {
            continue;
        }
        // not able to merge, so need to produce entry and compare against
        // expected rids before starting to merge on the next entry
        bool rc = compareExpected(mEntry, ridValues, ridPos, true);
        BOOST_REQUIRE(rc);
        mEntry.setEntryTuple(entryList[i]->entryTuple);
    }
    // if this is the last remaining entry, compare it against
    // expected rid values
    if (ridPos < ridValues.size()) {
        bool rc = compareExpected(mEntry, ridValues, ridPos, true);
        BOOST_REQUIRE(rc);
    }

    BOOST_REQUIRE(ridPos == ridValues.size());

    scratchAccessor.pSegment->deallocatePageRange(NULL_PAGE_ID, NULL_PAGE_ID);
}

void LbmEntryTest::testler5920

(

)

Definition at line 653 of file LbmEntryTest.cpp.

References SegPageLock::accessSegment(), allocateBuf(), attrDesc_bitmap, attrDesc_int64, bitmapColSize, bufSize, bufUsed, compareExpected(), TupleData::compute(), entryTuple, entryTupleDesc, LbmEntry::getScratchBufferSize(), LbmEntry::init(), LbmSegment::LbmOneByteSize, LbmEntry::mergeEntry(), StandardTypeDescriptorFactory::newDataType(), NULL_PAGE_ID, opaqueToInt(), CacheTestBase::pCache, SegmentAccessor::pSegment, SegStorageTestBase::pSegmentFactory, LbmEntry::setEntryTuple(), STANDARD_TYPE_INT_64, STANDARD_TYPE_VARBINARY, and stdTypeFactory.

Referenced by LbmEntryTest().

{
    std::vector<SharedLbmEntryInfo> entryList;
    std::vector<LcsRid> ridValues;

    // bitmap entries will be created without a leading key, so the
    // first column is the startRid
    // initialize scratch accessor for scratch buffers used to
    // construct bitmaps
    SegmentAccessor scratchAccessor =
        pSegmentFactory->newScratchSegment(pCache, 10);
    bufSize = scratchAccessor.pSegment->getUsablePageSize();
    SegPageLock bufferLock;
    bufferLock.accessSegment(scratchAccessor);
    bufUsed = bufSize;

    bitmapColSize = 16;
    attrDesc_bitmap =
        TupleAttributeDescriptor(
            stdTypeFactory.newDataType(STANDARD_TYPE_VARBINARY),
            true, bitmapColSize);
    attrDesc_int64 =
        TupleAttributeDescriptor(
            stdTypeFactory.newDataType(STANDARD_TYPE_INT_64));

    entryTupleDesc.push_back(attrDesc_int64);
    entryTupleDesc.push_back(attrDesc_bitmap);
    entryTupleDesc.push_back(attrDesc_bitmap);
    entryTuple.compute(entryTupleDesc);

    SharedLbmEntryInfo pListElement = SharedLbmEntryInfo(new LbmEntryInfo());

    // first entry -- full bitmap

    pListElement->pBuf = allocateBuf(bufferLock);
    pListElement->entry.init(
        pListElement->pBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    entryList.push_back(pListElement);
    LcsRid rid = LcsRid(0);
    ridValues.push_back(rid);
    entryTuple[0].pData = (PConstBuffer) &rid;
    entryTuple[1].cbData = 0;
    entryTuple[1].pData = NULL;
    entryTuple[2].cbData = 0;
    entryTuple[2].pData = NULL;
    entryList.back()->entry.setEntryTuple(entryTuple);
    for (uint i = 0; i < bitmapColSize - 2; i++) {
        rid = LcsRid((i + 1) * 8);
        entryList.back()->entry.setRID(rid);
        ridValues.push_back(rid);
    }
    LcsRid overlapStartRid = LcsRid((bitmapColSize - 2) * 8);

    // second entry -- compressed bitmap that overlaps the last byte of the
    // first entry

    pListElement = SharedLbmEntryInfo(new LbmEntryInfo());
    pListElement->pBuf = allocateBuf(bufferLock);
    pListElement->entry.init(
        pListElement->pBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    entryList.push_back(pListElement);
    entryTuple[0].pData = (PConstBuffer) &overlapStartRid;
    entryTuple[1].pData = NULL;
    entryTuple[1].cbData = 0;
    rid = LcsRid(overlapStartRid + 4);
    ridValues.push_back(rid);
    uint8_t byte =
        (uint8_t) (1 << (opaqueToInt(rid) % LbmSegment::LbmOneByteSize));
    rid = LcsRid(overlapStartRid + 5);
    ridValues.push_back(rid);
    byte |= (uint8_t) (1 << (opaqueToInt(rid) % LbmSegment::LbmOneByteSize));
    entryTuple[2].pData = &byte;
    entryTuple[2].cbData = 1;
    entryList.back()->entry.setEntryTuple(entryTuple);

    // third entry -- singleton

    pListElement = SharedLbmEntryInfo(new LbmEntryInfo());
    pListElement->pBuf = allocateBuf(bufferLock);
    pListElement->entry.init(
        pListElement->pBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    entryList.push_back(pListElement);
    rid = LcsRid(overlapStartRid + 8 + 2);
    ridValues.push_back(rid);
    entryTuple[0].pData = (PConstBuffer) &rid;
    entryTuple[1].pData = NULL;
    entryTuple[1].cbData = 0;
    entryTuple[2].pData = NULL;
    entryTuple[2].cbData = 0;
    entryList.back()->entry.setEntryTuple(entryTuple);

    // produce the tuples corresponding to each LbmEntry
    for (uint i = 0; i < entryList.size(); i++) {
        entryList[i]->entryTuple = entryList[i]->entry.produceEntryTuple();
    }

    uint ridPos = 0;
    PBuffer mergeBuf = allocateBuf(bufferLock);
    LbmEntry mEntry;
    mEntry.init(
        mergeBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);

    mEntry.setEntryTuple(entryList[0]->entryTuple);

    // merge the the overlapping byte; mergeEntry should return true
    bool rc = mEntry.mergeEntry(entryList[1]->entryTuple);
    BOOST_REQUIRE(rc);

    // this merge should overflow the currentEntry
    rc = mEntry.mergeEntry(entryList[2]->entryTuple);
    BOOST_REQUIRE(!rc);
    rc = compareExpected(mEntry, ridValues, ridPos, true);
    BOOST_REQUIRE(rc);

    // make sure the previous merge didn't add any extra rids
    mEntry.setEntryTuple(entryList[2]->entryTuple);
    rc = compareExpected(mEntry, ridValues, ridPos, true);
    BOOST_REQUIRE(rc);

    scratchAccessor.pSegment->deallocatePageRange(NULL_PAGE_ID, NULL_PAGE_ID);
}

void LbmEntryTest::testZeroBytes

(

)

Definition at line 779 of file LbmEntryTest.cpp.

References SegPageLock::accessSegment(), allocateBuf(), attrDesc_bitmap, attrDesc_int64, bitmapColSize, bufSize, bufUsed, compareExpected(), TupleData::compute(), entryTuple, entryTupleDesc, LbmEntry::getScratchBufferSize(), LbmEntry::init(), LbmSegment::LbmOneByteSize, LbmEntry::mergeEntry(), StandardTypeDescriptorFactory::newDataType(), NULL_PAGE_ID, opaqueToInt(), CacheTestBase::pCache, SegmentAccessor::pSegment, SegStorageTestBase::pSegmentFactory, LbmSegment::roundToByteBoundary(), LbmEntry::setEntryTuple(), STANDARD_TYPE_INT_64, STANDARD_TYPE_VARBINARY, and stdTypeFactory.

Referenced by LbmEntryTest().

{
    // Exercise creating bitmaps that contain zero bytes requiring various
    // lengths to encode.

    std::vector<SharedLbmEntryInfo> entryList;
    std::vector<LcsRid> ridValues;

    SegmentAccessor scratchAccessor =
        pSegmentFactory->newScratchSegment(pCache, 10);
    bufSize = scratchAccessor.pSegment->getUsablePageSize();
    SegPageLock bufferLock;
    bufferLock.accessSegment(scratchAccessor);
    bufUsed = bufSize;

    bitmapColSize = 16;
    attrDesc_bitmap =
        TupleAttributeDescriptor(
            stdTypeFactory.newDataType(STANDARD_TYPE_VARBINARY),
            true, bitmapColSize);
    attrDesc_int64 =
        TupleAttributeDescriptor(
            stdTypeFactory.newDataType(STANDARD_TYPE_INT_64));

    entryTupleDesc.push_back(attrDesc_int64);
    entryTupleDesc.push_back(attrDesc_bitmap);
    entryTupleDesc.push_back(attrDesc_bitmap);
    entryTuple.compute(entryTupleDesc);

    SharedLbmEntryInfo pListElement = SharedLbmEntryInfo(new LbmEntryInfo());

    // 1st entry -- start with rid 1

    pListElement->pBuf = allocateBuf(bufferLock);
    pListElement->entry.init(
        pListElement->pBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    entryList.push_back(pListElement);
    LcsRid rid = LcsRid(1);
    ridValues.push_back(rid);
    LcsRid roundedRid = LbmSegment::roundToByteBoundary(rid);
    entryTuple[0].pData = (PConstBuffer) &roundedRid;
    entryTuple[1].pData = NULL;
    uint8_t byte =
        (uint8_t) (1 << (opaqueToInt(rid) % LbmSegment::LbmOneByteSize));
    entryTuple[2].pData = &byte;
    entryTuple[2].cbData = 1;
    entryList.back()->entry.setEntryTuple(entryTuple);

    // 2nd entry -- previous rid + 2^16*8.  This will require 2 bytes to store
    // the zero bytes in between this rid and the previous.

    pListElement = SharedLbmEntryInfo(new LbmEntryInfo());
    pListElement->pBuf = allocateBuf(bufferLock);
    pListElement->entry.init(
        pListElement->pBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    entryList.push_back(pListElement);
    rid = LcsRid(rid + (int64_t) pow(2.0,16.0)*8);
    ridValues.push_back(rid);
    entryTuple[0].pData = (PConstBuffer) &rid;
    entryTuple[1].pData = NULL;
    entryTuple[2].pData = NULL;
    entryList.back()->entry.setEntryTuple(entryTuple);

    // 3rd entry -- previous rid + 2^24*8.  This will require 3 bytes to
    // store the zero bytes in between this rid and the previous.

    pListElement = SharedLbmEntryInfo(new LbmEntryInfo());
    pListElement->pBuf = allocateBuf(bufferLock);
    pListElement->entry.init(
        pListElement->pBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    entryList.push_back(pListElement);
    rid = LcsRid(rid + (int64_t) pow(2.0,24.0)*8);
    ridValues.push_back(rid);
    entryTuple[0].pData = (PConstBuffer) &rid;
    entryTuple[1].pData = NULL;
    entryTuple[2].pData = NULL;
    entryList.back()->entry.setEntryTuple(entryTuple);

    // 4th entry -- previous rid + ((2^24)+1)*8.  The zero bytes in this case
    // cannot be encoded in 3 bytes, so a new bitmap entry will be created.

    pListElement = SharedLbmEntryInfo(new LbmEntryInfo());
    pListElement->pBuf = allocateBuf(bufferLock);
    pListElement->entry.init(
        pListElement->pBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);
    entryList.push_back(pListElement);
    rid = LcsRid(rid + (int64_t) (pow(2.0,24.0)+1)*8);
    ridValues.push_back(rid);
    entryTuple[0].pData = (PConstBuffer) &rid;
    entryTuple[1].pData = NULL;
    entryTuple[2].pData = NULL;
    entryList.back()->entry.setEntryTuple(entryTuple);

    // produce the tuples corresponding to each LbmEntry
    for (uint i = 0; i < entryList.size(); i++) {
        entryList[i]->entryTuple = entryList[i]->entry.produceEntryTuple();
    }

    uint ridPos = 0;
    PBuffer mergeBuf = allocateBuf(bufferLock);
    LbmEntry mEntry;
    mEntry.init(
        mergeBuf, NULL, LbmEntry::getScratchBufferSize(bitmapColSize),
        entryTupleDesc);

    mEntry.setEntryTuple(entryList[0]->entryTuple);
    for (uint i = 1; i < entryList.size(); i++) {
        if (mEntry.mergeEntry(entryList[i]->entryTuple)) {
            continue;
        }
        // not able to merge, so need to produce entry and compare against
        // expected rids before starting to merge on the next entry; pass
        // in false for the testContains parameter to avoid excessive
        // containsRids() calls
        bool rc = compareExpected(mEntry, ridValues, ridPos, false);
        BOOST_REQUIRE(rc);
        mEntry.setEntryTuple(entryList[i]->entryTuple);
    }
    // if this is the last remaining entry, compare it against
    // expected rid values
    if (ridPos < ridValues.size()) {
        bool rc = compareExpected(mEntry, ridValues, ridPos, false);
        BOOST_REQUIRE(rc);
    }

    BOOST_REQUIRE(ridPos == ridValues.size());

    scratchAccessor.pSegment->deallocatePageRange(NULL_PAGE_ID, NULL_PAGE_ID);
}

void LbmEntryTest::testMergeSingletonInFront1

(

)

Definition at line 1108 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(77));

    // singleton rid needs to be in a byte in front of the current entry
    ridValues.push_back(LcsRid(1));
    testMergeSingleton(24, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonInFront2

(

)

Definition at line 1123 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(20));

    // singleton rid needs to be in a byte in front of the current entry --
    // current entry is also a singleton
    ridValues.push_back(LcsRid(1));
    testMergeSingleton(24, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonMidSegment1

(

)

Definition at line 1135 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(77));

    // singleton rid will be set in an existing rid range -- first rid in
    // segment
    ridValues.push_back(LcsRid(8));
    testMergeSingleton(24, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonMidSegment2

(

)

Definition at line 1151 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(77));

    // singleton rid will be set in an existing rid range -- rid in the middle
    ridValues.push_back(LcsRid(17));
    testMergeSingleton(24, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonMidSegment3

(

)

Definition at line 1166 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(77));

    // singleton rid will be set in an existing rid range -- rid at the end
    ridValues.push_back(LcsRid(31));
    testMergeSingleton(24, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonMidSegment4

(

)

Definition at line 1181 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(77));

    // singleton rid will be set in an existing rid range -- rid in the 2nd
    // byte segment
    ridValues.push_back(LcsRid(56));
    testMergeSingleton(24, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonEndSegment

(

)

Definition at line 1197 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(77));

    // singleton rid is in the byte adjacent to the last byte in a segment
    ridValues.push_back(LcsRid(33));
    testMergeSingleton(24, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonStartSegment1

(

)

Definition at line 1212 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(77));

    // singleton rid is in the byte in front of the first byte in a segment
    // that's not the first byte in an entry -- last bit in new segment
    ridValues.push_back(LcsRid(55));
    testMergeSingleton(24, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonStartSegment2

(

)

Definition at line 1228 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(77));

    // singleton rid is in the byte in front of the first byte in a segment
    // that's not the first byte in an entry -- first bit in new segment
    ridValues.push_back(LcsRid(64));
    testMergeSingleton(24, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonInBetweenSegment

(

)

Definition at line 1244 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(77));

    // singleton rid is in a byte currently represented by trailing zeros, but
    // the new byte is not adjacent to an existing segment
    ridValues.push_back(LcsRid(40));
    testMergeSingleton(24, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonSplitLeft1

(

)

Definition at line 1260 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(77));

    // singleton rid goes to the left side of the split entry -- at the end
    // of the new split entry
    ridValues.push_back(LcsRid(39));
    testMergeSingleton(19, ridValues, 1, true);
}

void LbmEntryTest::testMergeSingletonSplitLeft2

(

)

Definition at line 1276 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(35));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(77));

    // singleton rid goes to the left side of the split entry -- move a
    // segment from the left to the right to minimize the space in the entry
    // that the new rid will be inserted into
    ridValues.push_back(LcsRid(18));
    testMergeSingleton(19, ridValues, 1, true);
}

void LbmEntryTest::testMergeSingletonSplitRight1

(

)

Definition at line 1292 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(85));

    // singleton rid goes to the right side of the split entry -- in the middle
    // of the split entry
    ridValues.push_back(LcsRid(71));
    testMergeSingleton(19, ridValues, 1, true);
}

void LbmEntryTest::testMergeSingletonSplitRight2

(

)

Definition at line 1308 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(544));
    ridValues.push_back(LcsRid(560));
    ridValues.push_back(LcsRid(576));
    ridValues.push_back(LcsRid(1088));

    // singleton rid goes to the right side of the split entry -- ensure
    // entry is split at the appropriate boundary; otherwise, there won't
    // be space in the split entry
    ridValues.push_back(LcsRid(832));
    testMergeSingleton(20, ridValues, 1, true);
}

void LbmEntryTest::testMergeSingletonSplitHalf

(

)

Definition at line 1324 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(539));

    // only 2 segments with the left segment being bigger; ensure that the new
    // rid fits when merged into the left entry
    ridValues.push_back(LcsRid(283));
    testMergeSingleton(18, ridValues, 1, true);
}

void LbmEntryTest::testMergeSingletonSplitLast

(

)

Definition at line 1339 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(48));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(64));
    ridValues.push_back(LcsRid(77));
    ridValues.push_back(LcsRid(87));
    ridValues.push_back(LcsRid(95));
    ridValues.push_back(LcsRid(96));

    // singleton rid goes to the left side of the split entry; only the last
    // segment in the original is split to the right
    ridValues.push_back(LcsRid(47));
    testMergeSingleton(23, ridValues, 1, true);
}

void LbmEntryTest::testMergeSingletonSplitMaxSegments

(

)

Definition at line 1360 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(0));
    // create several segments that max out at 16 bytes
    for (int i = 250; i < 600; i += 8) {
        ridValues.push_back(LcsRid(i));
    }
    ridValues.push_back(LcsRid(617));

    // inserting a new rid requires spltting in between two of the 16-byte
    // segments
    ridValues.push_back(LcsRid(125));
    testMergeSingleton(63, ridValues, 1, true);
}

void LbmEntryTest::testMergeSingletonZeros1

(

)

Definition at line 1377 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(4));
    // (12+2)*8 = 112
    ridValues.push_back(LcsRid(114));
    ridValues.push_back(LcsRid(123));

    // singleton rid replaces a trailing zero byte, which results in the
    // number of trailing zero bytes decreasing by 1
    ridValues.push_back(LcsRid(47));
    testMergeSingleton(24, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonZeros2

(

)

Definition at line 1392 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(4));
    // ((2^16)+1)*8 = 524288 (3 bytes required to encode zero length)
    ridValues.push_back(LcsRid(524296));
    ridValues.push_back(LcsRid(524305));

    // singleton rid replaces a trailing zero byte, which results in the
    // number of trailing zero bytes decreasing by 1; new byte is adjacent
    // to first
    ridValues.push_back(LcsRid(13));
    testMergeSingleton(24, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonZeros3

(

)

Definition at line 1408 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(4));
    // (12+2)*8 = 112
    ridValues.push_back(LcsRid(114));
    ridValues.push_back(LcsRid(123));

    // singleton rid replaces a trailing zero byte, which results in the
    // number of trailing zero bytes decreasing by 1 but addition of new
    // segment requires a split of the current entry
    ridValues.push_back(LcsRid(60));
    testMergeSingleton(17, ridValues, 1, true);
}

void LbmEntryTest::testMergeSingletonZeros4

(

)

Definition at line 1424 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(4));
    // (12+2)*8 = 112
    ridValues.push_back(LcsRid(114));
    ridValues.push_back(LcsRid(123));

    // current entry is currently at max size; adding a new singleton rid
    // requires a new segment but doing so does not require a split because
    // the new segment replaces the trailing zero byte
    ridValues.push_back(LcsRid(13));
    testMergeSingleton(17, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonAfterSplit

(

)

Definition at line 1458 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(48));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(64));
    ridValues.push_back(LcsRid(77));
    ridValues.push_back(LcsRid(87));
    ridValues.push_back(LcsRid(95));
    ridValues.push_back(LcsRid(96));

    // singleton rid goes to the left side of the split entry; only the last
    // segment in the original is split to the right; add another singleton
    // after the split
    ridValues.push_back(LcsRid(33));
    ridValues.push_back(LcsRid(47));
    testMergeSingleton(23, ridValues, 2, true);
}

void LbmEntryTest::testMergeSingletonCombine

(

)

Definition at line 1440 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(9));
    ridValues.push_back(LcsRid(18));
    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(60));
    ridValues.push_back(LcsRid(77));
    ridValues.push_back(LcsRid(86));
    ridValues.push_back(LcsRid(111));

    // singleton rid goes in the middle of 2 segments, which results in the 3
    // segments being combined into 1
    ridValues.push_back(LcsRid(71));
    testMergeSingleton(24, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonMaxSeg

(

)

Definition at line 1481 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(0));

    ridValues.push_back(LcsRid(27));
    ridValues.push_back(LcsRid(36));
    ridValues.push_back(LcsRid(45));
    ridValues.push_back(LcsRid(54));
    ridValues.push_back(LcsRid(63));
    ridValues.push_back(LcsRid(64));
    ridValues.push_back(LcsRid(72));
    ridValues.push_back(LcsRid(81));
    ridValues.push_back(LcsRid(90));
    ridValues.push_back(LcsRid(99));
    ridValues.push_back(LcsRid(108));
    ridValues.push_back(LcsRid(117));
    ridValues.push_back(LcsRid(126));
    ridValues.push_back(LcsRid(135));
    ridValues.push_back(LcsRid(136));
    ridValues.push_back(LcsRid(145));

    // attempt to insert singleton rid in front of a segment that currently
    // has a segment length of 16
    ridValues.push_back(LcsRid(18));
    testMergeSingleton(32, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonRandom1

(

)

Definition at line 1545 of file LbmEntryTest.cpp.

References testMergeSingletonRandom().

Referenced by LbmEntryTest().

{
    testMergeSingletonRandom(50, 1000);
}

void LbmEntryTest::testMergeSingletonRandom2

(

)

Definition at line 1550 of file LbmEntryTest.cpp.

References testMergeSingletonRandom().

Referenced by LbmEntryTest().

{
    testMergeSingletonRandom(100, 10000);
}

void LbmEntryTest::testMergeSingletonWithSingleton1

(

)

Definition at line 1555 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(7));

    ridValues.push_back(LcsRid(1));
    testMergeSingleton(16, ridValues, 1, false);
}

void LbmEntryTest::testMergeSingletonWithSingleton2

(

)

Definition at line 1565 of file LbmEntryTest.cpp.

References testMergeSingleton().

Referenced by LbmEntryTest().

{
    std::vector<LcsRid> ridValues;

    ridValues.push_back(LcsRid(50));

    ridValues.push_back(LcsRid(1));
    // not enough space so the entries should get split into 2
    testMergeSingleton(10, ridValues, 1, true);
}

void SegStorageTestBase::openStorage

(

DeviceMode

openMode

)

[virtual, inherited]

Reimplemented from CacheTestBase.

Reimplemented in SegmentTestBase.

Definition at line 31 of file SegStorageTestBase.cpp.

References SegStorageTestBase::openSegmentStorage(), and CacheTestBase::openStorage().

Referenced by SegStorageTestBase::openRandomSegment(), SegmentTestBase::openStorage(), LhxHashTableTest::testCaseSetUp(), ExecStreamTestBase::testCaseSetUp(), BTreeTest::testCaseSetUp(), BTreeReadersTest::testCaseSetUp(), testCaseSetUp(), SegPageIterTest::testIter(), SegPageEntryIterTest::testIter(), SegStreamTest::testMarkReset(), SegStreamTest::testReadSeg(), LogicalTxnTest::testTxn(), SegStreamTest::testWriteSeg(), and SegStreamTest::testWriteSpillAndRead().

{
    CacheTestBase::openStorage(openMode);
    openSegmentStorage(openMode);
}

void SegStorageTestBase::openSegmentStorage

(

DeviceMode

openMode

)

[virtual, inherited]

Reimplemented in LinearViewSegmentTest, SnapshotSegmentTestBase, and VersionedSegmentTest.

Definition at line 37 of file SegStorageTestBase.cpp.

References CacheTestBase::cbPageFull, DeviceMode::create, SegStorageTestBase::createLinearDeviceSegment(), CacheTestBase::dataDeviceId, SegStorageTestBase::pLinearSegment, and CacheTestBase::pRandomAccessDevice.

Referenced by VersionedSegmentTest::openSegmentStorage(), and SegStorageTestBase::openStorage().

{
    pLinearSegment = createLinearDeviceSegment(
        dataDeviceId,
        openMode.create ? 0
        : pRandomAccessDevice->getSizeInBytes() / cbPageFull);
}

void SegStorageTestBase::openRandomSegment

(

)

[virtual, inherited]

Reimplemented in LcsClusterReplaceExecStreamTest.

Definition at line 45 of file SegStorageTestBase.cpp.

References SegStorageTestBase::closeStorage(), DeviceMode::load, SegStorageTestBase::openStorage(), SegStorageTestBase::pLinearSegment, SegStorageTestBase::pRandomSegment, and SegStorageTestBase::pSegmentFactory.

Referenced by RandomAllocationSegmentTest::testAllocateAndDeallocate(), LhxHashTableTest::testCaseSetUp(), ExecStreamUnitTestBase::testCaseSetUp(), BTreeTest::testCaseSetUp(), and BTreeReadersTest::testCaseSetUp().

{
    // reopen will interpret pages as already allocated, which
    // is what RandomAllocationSegment expects
    closeStorage();
    openStorage(DeviceMode::load);
    pRandomSegment = pSegmentFactory->newRandomAllocationSegment(
        pLinearSegment, true);
    pLinearSegment.reset();
}

SharedSegment SegStorageTestBase::createLinearDeviceSegment	(	DeviceId	deviceId,
		uint	nPages
	)			[inherited]

Definition at line 56 of file SegStorageTestBase.cpp.

References LinearDeviceSegmentParams::firstBlockId, LinearDeviceSegmentParams::nPagesAllocated, LinearDeviceSegmentParams::nPagesMin, CacheTestBase::pCache, SegStorageTestBase::pSegmentFactory, CompoundId::setBlockNum(), and CompoundId::setDeviceId().

Referenced by VersionedSegmentTest::openSegmentStorage(), SnapshotSegmentTestBase::openSegmentStorage(), SegStorageTestBase::openSegmentStorage(), and LinearViewSegmentTest::openSegmentStorage().

{
    BlockId blockId(0);
    CompoundId::setDeviceId(blockId,deviceId);
    CompoundId::setBlockNum(blockId,0);
    LinearDeviceSegmentParams deviceParams;
    deviceParams.firstBlockId = blockId;
    deviceParams.nPagesMin = nPages;
    deviceParams.nPagesAllocated = nPages;
    return pSegmentFactory->newLinearDeviceSegment(
        pCache,deviceParams);
}

void SegStorageTestBase::closeLinearSegment

(

)

[inherited]

Definition at line 70 of file SegStorageTestBase.cpp.

References SegStorageTestBase::pLinearSegment.

Referenced by VersionedSegmentTest::closeStorage(), SnapshotSegmentTestBase::closeStorage(), SegStorageTestBase::closeStorage(), and SnapshotSegmentTest::testUncommittedReads().

{
    if (pLinearSegment) {
        assert(pLinearSegment.unique());
        pLinearSegment.reset();
    }
}

void SegStorageTestBase::closeRandomSegment

(

)

[inherited]

Definition at line 78 of file SegStorageTestBase.cpp.

References SegStorageTestBase::pRandomSegment.

Referenced by VersionedSegmentTest::closeStorage(), and SegStorageTestBase::closeStorage().

{
    if (pRandomSegment) {
        assert(pRandomSegment.unique());
        pRandomSegment.reset();
    }
}

void SegStorageTestBase::closeVersionedRandomSegment

(

)

[inherited]

Definition at line 86 of file SegStorageTestBase.cpp.

References SegStorageTestBase::pVersionedRandomSegment.

Referenced by SnapshotSegmentTestBase::closeStorage(), and SegStorageTestBase::closeStorage().

{
    if (pVersionedRandomSegment) {
        assert(pVersionedRandomSegment.unique());
        pVersionedRandomSegment.reset();
    }
}

void SegStorageTestBase::closeSnapshotRandomSegment

(

)

[inherited]

Definition at line 94 of file SegStorageTestBase.cpp.

References SegStorageTestBase::pSnapshotRandomSegment.

Referenced by SnapshotSegmentTestBase::closeStorage().

{
    if (pSnapshotRandomSegment) {
        assert(pSnapshotRandomSegment.unique());
        pSnapshotRandomSegment.reset();
    }
}

void SegStorageTestBase::closeStorage

(

)

[virtual, inherited]

Reimplemented from CacheTestBase.

Reimplemented in SnapshotSegmentTestBase, and VersionedSegmentTest.

Definition at line 102 of file SegStorageTestBase.cpp.

References SegStorageTestBase::closeLinearSegment(), SegStorageTestBase::closeRandomSegment(), CacheTestBase::closeStorage(), and SegStorageTestBase::closeVersionedRandomSegment().

Referenced by VersionedSegmentTest::closeStorage(), SnapshotSegmentTestBase::closeStorage(), SegStorageTestBase::openRandomSegment(), SegPageIterTest::testIter(), SegPageEntryIterTest::testIter(), SegStreamTest::testMarkReset(), SegStreamTest::testReadSeg(), SegmentTestBase::testSingleThread(), SegStreamTest::testWriteSeg(), and SegStreamTest::testWriteSpillAndRead().

{
    closeLinearSegment();
    closeRandomSegment();
    closeVersionedRandomSegment();
    // TODO:  assert pSegmentFactory.unique(), but not here
    CacheTestBase::closeStorage();
}

Cache & CacheTestBase::getCache

(

)

[inherited]

Definition at line 42 of file CacheTestBase.cpp.

References CacheTestBase::pCache.

Referenced by CacheTest::lockPage(), CacheTest::prefetchBatch(), SegmentTestBase::prefetchPage(), CacheTest::prefetchPage(), PagingTestBase::testCacheResize(), PagingTestBase::testCheckpoint(), PagingTestBase::testOp(), PagingTestBase::testScratch(), SegmentTestBase::unlockPage(), and CacheTest::unlockPage().

{
    return *pCache;
}

SharedCache CacheTestBase::newCache

(

)

[virtual, inherited]

Definition at line 66 of file CacheTestBase.cpp.

References CacheTestBase::cacheParams, Cache::newCache(), CacheTestBase::victimLRU, CacheTestBase::victimPolicy, CacheTestBase::victimRandom, and CacheTestBase::victimTwoQ.

Referenced by CacheTestBase::openStorage().

{
    switch (victimPolicy) {
    case victimRandom:
        return SharedCache(
            new RandomCache(cacheParams),
            ClosableObjectDestructor());
    case victimLRU:
        return SharedCache(
            new LRUCache(cacheParams),
            ClosableObjectDestructor());
    case victimTwoQ:
        return Cache::newCache(cacheParams);
    default:
        permAssert(false);
    }
}

SharedRandomAccessDevice CacheTestBase::openDevice	(	std::string	devName,
		DeviceMode	openMode,
		uint	nDevicePages,
		DeviceId	deviceId
	)			[inherited]

Definition at line 84 of file CacheTestBase.cpp.

References CacheTestBase::cbPageFull, DeviceMode::create, CacheTestBase::pCache, and FileSystem::remove().

Referenced by VersionedSegmentTest::openSegmentStorage(), SnapshotSegmentTestBase::openSegmentStorage(), and CacheTestBase::openStorage().

{
    if (openMode.create) {
        FileSystem::remove(devName.c_str());
    }
    SharedRandomAccessDevice pDevice(
        new RandomAccessFileDevice(devName,openMode));
    if (openMode.create) {
        pDevice->setSizeInBytes(nDevicePages*cbPageFull);
    }
    pCache->registerDevice(deviceId,pDevice);
    return pDevice;
}

void CacheTestBase::closeDevice	(	DeviceId	deviceId,
		SharedRandomAccessDevice &	pDevice
	)			[inherited]

Definition at line 130 of file CacheTestBase.cpp.

References CHECKPOINT_FLUSH_AND_UNMAP, and CacheTestBase::pCache.

Referenced by VersionedSegmentTest::closeStorage(), SnapshotSegmentTestBase::closeStorage(), and CacheTestBase::closeStorage().

{
    if (!pDevice) {
        return;
    }
    DeviceIdPagePredicate pagePredicate(deviceId);
    pCache->checkpointPages(pagePredicate,CHECKPOINT_FLUSH_AND_UNMAP);
    pCache->unregisterDevice(deviceId);
    assert(pDevice.unique());
    pDevice.reset();
}

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::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

uint LbmEntryTest::bitmapColSize [private]

Definition at line 62 of file LbmEntryTest.cpp.

Referenced by allocateBuf(), newLbmEntry(), testldb35(), testler5920(), testMergeEntry(), testMergeSingleton(), and testZeroBytes().

StandardTypeDescriptorFactory LbmEntryTest::stdTypeFactory [private]

Definition at line 63 of file LbmEntryTest.cpp.

Referenced by testldb35(), testler5920(), testMergeEntry(), testMergeSingleton(), and testZeroBytes().

TupleAttributeDescriptor LbmEntryTest::attrDesc_bitmap [private]

Definition at line 64 of file LbmEntryTest.cpp.

Referenced by testldb35(), testler5920(), testMergeEntry(), testMergeSingleton(), and testZeroBytes().

TupleAttributeDescriptor LbmEntryTest::attrDesc_int64 [private]

Definition at line 65 of file LbmEntryTest.cpp.

Referenced by testldb35(), testler5920(), testMergeEntry(), testMergeSingleton(), and testZeroBytes().

TupleDescriptor LbmEntryTest::entryTupleDesc [private]

Definition at line 66 of file LbmEntryTest.cpp.

Referenced by newLbmEntry(), recurseCombos(), testCaseTearDown(), testldb35(), testler5920(), testMergeEntry(), testMergeSingleton(), and testZeroBytes().

uint LbmEntryTest::bufSize [private]

Definition at line 67 of file LbmEntryTest.cpp.

Referenced by allocateBuf(), testldb35(), testler5920(), testMergeEntry(), and testZeroBytes().

uint LbmEntryTest::bufUsed [private]

Definition at line 68 of file LbmEntryTest.cpp.

Referenced by allocateBuf(), testldb35(), testler5920(), testMergeEntry(), and testZeroBytes().

PBuffer LbmEntryTest::pBuf [private]

Definition at line 69 of file LbmEntryTest.cpp.

Referenced by allocateBuf().

TupleData LbmEntryTest::entryTuple [private]

Definition at line 70 of file LbmEntryTest.cpp.

Referenced by newLbmEntry(), recurseCombos(), testldb35(), testler5920(), testMergeEntry(), testMergeSingleton(), and testZeroBytes().

SharedSegmentFactory SegStorageTestBase::pSegmentFactory [protected, inherited]

Definition at line 40 of file SegStorageTestBase.h.

Referenced by BackupRestoreTest::backup(), SegStorageTestBase::createLinearDeviceSegment(), LogicalTxnTest::createRecoveryLog(), LbmSearchTest::initBTreeExecStreamParam(), LbmLoadBitmapTest::initBTreeExecStreamParam(), LcsClusterReplaceExecStreamTest::initClusterAppendParams(), LbmExecStreamTestBase::initSorterExecStream(), LcsMultiClusterAppendTest::loadClusters(), LcsRowScanExecStreamTest::loadOneCluster(), LbmSearchTest::loadTableAndIndex(), LbmMinusExecStreamTest::newMinusStream(), ExecStreamTestBase::newStreamGraphEmbryo(), SegStorageTestBase::openRandomSegment(), VersionedSegmentTest::openSegmentStorage(), SnapshotSegmentTestBase::openSegmentStorage(), LinearViewSegmentTest::openSegmentStorage(), BackupRestoreTest::restore(), SegStorageTestBase::SegStorageTestBase(), LbmSplicerExecStreamTest::spliceInput(), ExecStreamTestSuite::testBTreeInsertExecStream(), LhxHashTableTest::testCaseSetUp(), LcsClusterReplaceExecStreamTest::testClusterReplace(), LhxAggExecStreamTest::testCountImpl(), ExecStreamTestSuite::testDoubleBufferExecStream(), ExecStreamGovernorTest::testGovernor(), LhxAggExecStreamTest::testGroupCountImpl(), LhxJoinExecStreamTest::testImpl(), ExternalSortExecStreamTest::testImpl(), BTreeTest::testInserts(), LbmIntersectExecStreamTest::testIntersect(), testldb35(), testler5920(), LbmLoadBitmapTest::testLoad(), LcsClusterAppendExecStreamTest::testLoadMultiCol(), LcsClusterAppendExecStreamTest::testLoadSingleCol(), testMergeEntry(), BTreeTest::testMultiKeySearches(), BTreeTest::testScan(), ExecStreamTestSuite::testScratchBufferExecStream(), LhxAggExecStreamTest::testSingleValueImpl(), FlatFileExecStreamTest::testStream(), LhxAggExecStreamTest::testSumImpl(), LogicalTxnTest::testTxn(), SnapshotSegmentTest::testUncommittedReads(), LbmUnionExecStreamTest::testUnion(), SegStreamTest::testWriteSpillAndRead(), and testZeroBytes().

SharedSegment SegStorageTestBase::pLinearSegment [protected, inherited]

Segment supporting linear page allocation.

Definition at line 45 of file SegStorageTestBase.h.

Referenced by SegStorageTestBase::closeLinearSegment(), LogicalTxnTest::createRecoveryLog(), SegmentTestBase::lockPage(), SegStorageTestBase::openRandomSegment(), VersionedSegmentTest::openSegmentStorage(), SnapshotSegmentTestBase::openSegmentStorage(), SegStorageTestBase::openSegmentStorage(), LinearViewSegmentTest::openSegmentStorage(), SegmentTestBase::openStorage(), SegmentTestBase::prefetchPage(), SnapshotSegmentTestBase::testAllocateAll(), LinearViewSegmentTest::testAllocateAll(), VersionedSegmentTest::testCheckpoint(), SegmentTestBase::testCheckpoint(), SegPageIterTest::testIter(), SegPageEntryIterTest::testIter(), SegStreamTest::testMarkReset(), SegStreamTest::testReadSeg(), VersionedSegmentTest::testRecovery(), LogicalTxnTest::testTxn(), SnapshotSegmentTest::testUncommittedReads(), SegStreamTest::testWriteSeg(), and VersionedSegmentTest::verifyPage().

SharedSegment SegStorageTestBase::pRandomSegment [protected, inherited]

(Optional) segment supporting random page allocation.

Definition at line 50 of file SegStorageTestBase.h.

Referenced by SegStorageTestBase::closeRandomSegment(), SnapshotSegmentTestBase::closeStorage(), LbmSplicerExecStreamTest::createBTree(), LbmSplicerExecStreamTest::initBTreeParam(), LbmSearchTest::initBTreeParam(), LbmLoadBitmapTest::initBTreeParam(), LbmLoadBitmapTest::initBTreeTupleDesc(), LcsClusterReplaceExecStreamTest::initClusterAppendParams(), LbmExecStreamTestBase::initSorterExecStream(), LcsClusterReplaceExecStreamTest::loadCluster(), LcsMultiClusterAppendTest::loadClusters(), LcsRowScanExecStreamTest::loadOneCluster(), LbmSearchTest::loadTableAndIndex(), SegStorageTestBase::openRandomSegment(), SnapshotSegmentTestBase::openSegmentStorage(), LinearViewSegmentTest::openSegmentStorage(), SegmentTestBase::openStorage(), SegmentTestBase::testAllocate(), RandomAllocationSegmentTest::testAllocateAndDeallocate(), ExecStreamTestSuite::testBTreeInsertExecStream(), BTreeTest::testBulkLoad(), LhxHashTableTest::testCaseSetUp(), BTreeTest::testCaseSetUp(), BTreeReadersTest::testCaseSetUp(), LcsRowScanExecStreamTest::testCaseSetUp(), LcsMultiClusterAppendTest::testCaseSetUp(), LcsClusterReplaceExecStreamTest::testCaseSetUp(), LcsClusterAppendExecStreamTest::testCaseSetUp(), LbmExecStreamTestBase::testCaseSetUp(), LcsClusterReplaceExecStreamTest::testClusterReplace(), LhxAggExecStreamTest::testCountImpl(), SegmentTestBase::testDeallocate(), LhxAggExecStreamTest::testGroupCountImpl(), LhxJoinExecStreamTest::testImpl(), ExternalSortExecStreamTest::testImpl(), BTreeTest::testInserts(), LbmLoadBitmapTest::testLoad(), LcsClusterAppendExecStreamTest::testLoadMultiCol(), LcsClusterAppendExecStreamTest::testLoadSingleCol(), ExecStreamTestSuite::testMergeImplicitPullInputs(), BTreeTest::testMultiKeySearches(), BTreeReadersTest::testReaders(), LcsRowScanExecStreamTest::testScanOnEmptyCluster(), ExecStreamTestSuite::testSegBufferExecStream(), ExecStreamTestSuite::testSegBufferReaderWriterExecStream(), LhxAggExecStreamTest::testSingleValueImpl(), LhxAggExecStreamTest::testSumImpl(), and LbmUnionExecStreamTest::testUnion().

SharedSegment SegStorageTestBase::pVersionedRandomSegment [protected, inherited]

(Optional) segment supporting versioned random page allocation.

Definition at line 55 of file SegStorageTestBase.h.

Referenced by BackupRestoreTest::backup(), SnapshotSegmentTestBase::closeStorage(), SegStorageTestBase::closeVersionedRandomSegment(), SnapshotSegmentTest::deallocateOldPages(), SnapshotSegmentTestBase::openSegmentStorage(), BackupRestoreTest::restore(), LcsClusterReplaceExecStreamTest::testClusterReplace(), SnapshotSegmentTest::testRollback(), and SnapshotSegmentTest::testUncommittedReads().

SharedSegment SegStorageTestBase::pSnapshotRandomSegment [protected, inherited]

(Optional) segment supporting snapshot random page allocation.

Definition at line 60 of file SegStorageTestBase.h.

Referenced by SegStorageTestBase::closeSnapshotRandomSegment(), SnapshotSegmentTestBase::commitChanges(), SnapshotSegmentTestBase::openSegmentStorage(), LcsClusterReplaceExecStreamTest::testClusterReplace(), and SnapshotSegmentTest::testDeallocateOld().

VictimPolicy CacheTestBase::victimPolicy [protected, inherited]

VictimPolicy to instantiate.

Definition at line 53 of file CacheTestBase.h.

Referenced by CacheTestBase::CacheTestBase(), and CacheTestBase::newCache().

CacheParams CacheTestBase::cacheParams [protected, inherited]

Parameters for cache initialization.

Definition at line 58 of file CacheTestBase.h.

Referenced by CacheTestBase::CacheTestBase(), CacheTestBase::newCache(), BackupRestoreTest::testBackupCleanup(), BackupRestoreTest::testHeaderBackupRestore(), and SegPageEntryIterTest::testIter().

SharedCache CacheTestBase::pCache [protected, inherited]

Cache instance being tested.

Definition at line 63 of file CacheTestBase.h.

Referenced by BackupRestoreTest::backup(), CacheTestBase::closeDevice(), CacheTestBase::closeStorage(), LbmSplicerExecStreamTest::createBTree(), SegStorageTestBase::createLinearDeviceSegment(), LogicalTxnTest::createRecoveryLog(), BackupRestoreTest::createSnapshotData(), BackupRestoreTest::executeSnapshotTxn(), CacheTestBase::getCache(), LbmSearchTest::initBTreeExecStreamParam(), LbmLoadBitmapTest::initBTreeExecStreamParam(), LbmSearchTest::initBTreeParam(), LbmLoadBitmapTest::initBTreeParam(), LcsClusterReplaceExecStreamTest::initClusterAppendParams(), LbmExecStreamTestBase::initSorterExecStream(), LcsClusterReplaceExecStreamTest::loadCluster(), LcsMultiClusterAppendTest::loadClusters(), LcsRowScanExecStreamTest::loadOneCluster(), LbmSearchTest::loadTableAndIndex(), SegmentTestBase::lockPage(), LbmMinusExecStreamTest::newMinusStream(), ExecStreamTestBase::newStreamGraphEmbryo(), CacheTestBase::openDevice(), CacheTestBase::openStorage(), LcsClusterReplaceExecStreamTest::replaceCluster(), BackupRestoreTest::restore(), LbmSplicerExecStreamTest::spliceInput(), SegmentTestBase::testAllocate(), RandomAllocationSegmentTest::testAllocateAndDeallocate(), BackupRestoreTest::testBackupCleanup(), ExecStreamTestSuite::testBTreeInsertExecStream(), BTreeTest::testBulkLoad(), LhxHashTableTest::testCaseSetUp(), ExecStreamUnitTestBase::testCaseSetUp(), BTreeTest::testCaseSetUp(), BTreeReadersTest::testCaseSetUp(), LhxAggExecStreamTest::testCountImpl(), SegmentTestBase::testDeallocate(), SnapshotSegmentTest::testDeallocateOld(), ExecStreamTestSuite::testDoubleBufferExecStream(), ExecStreamGovernorTest::testGovernor(), LhxAggExecStreamTest::testGroupCountImpl(), BackupRestoreTest::testHeaderBackupRestore(), LhxJoinExecStreamTest::testImpl(), ExternalSortExecStreamTest::testImpl(), BTreeTest::testInserts(), LbmIntersectExecStreamTest::testIntersect(), SegPageIterTest::testIter(), SegPageEntryIterTest::testIter(), CacheTest::testLargeCacheInit(), CacheTest::testLargeCacheRequest(), testldb35(), testler5920(), LbmLoadBitmapTest::testLoad(), LcsClusterAppendExecStreamTest::testLoadMultiCol(), LcsClusterAppendExecStreamTest::testLoadSingleCol(), SegStreamTest::testMarkReset(), testMergeEntry(), BTreeTest::testMultiKeySearches(), CacheTest::testQuotaCacheAccessor(), BTreeReadersTest::testReaders(), SegStreamTest::testReadSeg(), BTreeTest::testScan(), LcsRowScanExecStreamTest::testScanOnEmptyCluster(), ExecStreamTestSuite::testScratchBufferExecStream(), LhxAggExecStreamTest::testSingleValueImpl(), FlatFileExecStreamTest::testStream(), LhxAggExecStreamTest::testSumImpl(), LogicalTxnTest::testTxn(), LogicalTxnTest::testTxnIdSequence(), LbmUnionExecStreamTest::testUnion(), SegStreamTest::testWriteSeg(), SegStreamTest::testWriteSpillAndRead(), testZeroBytes(), and BackupRestoreTest::verifySnapshotData().

SharedRandomAccessDevice CacheTestBase::pRandomAccessDevice [protected, inherited]

The default cached device.

Definition at line 68 of file CacheTestBase.h.

Referenced by BackupRestoreTest::backup(), CacheTestBase::closeStorage(), SegStorageTestBase::openSegmentStorage(), CacheTestBase::openStorage(), and BackupRestoreTest::restore().

uint CacheTestBase::nMemPages [protected, inherited]

Size of cache in memory pages.

Definition at line 73 of file CacheTestBase.h.

Referenced by CacheTestBase::CacheTestBase(), PagingTestBase::testCacheResize(), and ExecStreamTestBase::testCaseSetUp().

uint CacheTestBase::nDiskPages [protected, inherited]

Size of device in disk pages.

Definition at line 78 of file CacheTestBase.h.

Referenced by CacheTestBase::CacheTestBase(), LinearViewSegmentTest::LinearViewSegmentTest(), CacheTest::makeBlockId(), VersionedSegmentTest::openSegmentStorage(), SnapshotSegmentTestBase::openSegmentStorage(), LinearViewSegmentTest::openSegmentStorage(), CacheTestBase::openStorage(), SegStreamTest::SegStreamTest(), SnapshotSegmentTestBase::SnapshotSegmentTestBase(), SnapshotSegmentTest::testDeallocateOld(), PagingTestBase::testPrefetch(), PagingTestBase::testPrefetchBatch(), PagingTestBase::testRandomOp(), SnapshotSegmentTest::testRollback(), PagingTestBase::testSequentialOp(), and PagingTestBase::testSkipOp().

uint CacheTestBase::cbPageFull [protected, inherited]

Disk page size.

Definition at line 83 of file CacheTestBase.h.

Referenced by CacheTest::CacheTest(), CacheTestBase::CacheTestBase(), CacheTestBase::openDevice(), and SegStorageTestBase::openSegmentStorage().

DeviceId CacheTestBase::dataDeviceId [protected, inherited]

Fixed ID to assign to data device.

Definition at line 88 of file CacheTestBase.h.

Referenced by CacheTestBase::CacheTestBase(), CacheTestBase::closeStorage(), CacheTest::makeBlockId(), SnapshotSegmentTestBase::openSegmentStorage(), SegStorageTestBase::openSegmentStorage(), LinearViewSegmentTest::openSegmentStorage(), CacheTestBase::openStorage(), and PagingTestBase::testCheckpoint().

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::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/lucidera/test/LbmEntryTest.cpp

---