Fennel: DynamicDelegatingSegment Class Reference (original) (raw)

• Main Page

• Namespaces

• Classes

• Files

• Directories

• Related Pages

• Alphabetical List

• Class List

• Class Hierarchy

• Class Members

DynamicDelegatingSegment is similar to DelegatingSegment, except the delegating segment can be dynamically changed during the life of the segment. More...

#include <[DynamicDelegatingSegment.h](DynamicDelegatingSegment%5F8h-source.html)>

Inheritance diagram for DynamicDelegatingSegment:

List of all members.

Detailed Description

DynamicDelegatingSegment is similar to DelegatingSegment, except the delegating segment can be dynamically changed during the life of the segment.

As a result, we use a weak pointer to reference the delegating segment so the pointer becomes singular once that delegating segment is deallocated.

Definition at line 38 of file DynamicDelegatingSegment.h.

Member Typedef Documentation

Member Enumeration Documentation

Enumeration of the possible orderings of PageIds returned from allocatePageId.

The enumeration is from weakest to strongest ordering, and should not be changed.

Enumerator:

Definition at line 105 of file Segment.h.

Constructor & Destructor Documentation

| DynamicDelegatingSegment::~DynamicDelegatingSegment | ( | | ) | [virtual] | | ---------------------------------------------------- | - | | - | ----------- |

Member Function Documentation

| void DynamicDelegatingSegment::closeImpl | ( | | ) | [private, virtual] | | ---------------------------------------- | - | | - | -------------------- |

| BlockNum DynamicDelegatingSegment::getAllocatedSizeInPages | ( | | ) | [virtual] | | -------------------------------------------------------------------------------------------------------------- | - | | - | ----------- |

| BlockNum DynamicDelegatingSegment::getNumPagesOccupiedHighWater | ( | | ) | [virtual] | | ------------------------------------------------------------------------------------------------------------------- | - | | - | ----------- |

Returns the max number of pages occupied by this segment instance.

In other words, pages that are allocated but subsequently deallocated, are included in this count. Also, the count includes all pages used by the segment, including metadata pages.

Returns:

the max number of pages occupied by a segment

Implements Segment.

Definition at line 53 of file DynamicDelegatingSegment.cpp.

References delegateSegment.

00054 { 00055 SharedSegment pDelegateSegment = delegateSegment.lock(); 00056 return pDelegateSegment->getNumPagesOccupiedHighWater(); 00057 }

| BlockNum DynamicDelegatingSegment::getNumPagesExtended | ( | | ) | [virtual] | | ---------------------------------------------------------------------------------------------------------- | - | | - | ----------- |

Determines the successor of a given PageId.

This is an optional interface only supported by segments with some concept of page ordering.

Parameters:

Returns:

successor PageId

Implements Segment.

Definition at line 65 of file DynamicDelegatingSegment.cpp.

References delegateSegment.

Sets the successor of a given PageId.

This is an optional interface only supported by segments with some concept of modifiable ordering.

Parameters:

Implements Segment.

Definition at line 71 of file DynamicDelegatingSegment.cpp.

References delegateSegment.

00074 { 00075 SharedSegment pDelegateSegment = delegateSegment.lock(); 00076 pDelegateSegment->setPageSuccessor(pageId,successorId); 00077 }

| BlockId DynamicDelegatingSegment::translatePageId | ( | PageId | | ) | [virtual] | | ------------------------------------------------- | - | ------ | | - | ----------- |

| PageId DynamicDelegatingSegment::translateBlockId | ( | BlockId | | ) | [virtual] | | ------------------------------------------------- | - | ------- | | - | ----------- |

Allocates a page without locking it into memory.

Parameters:

Returns:

the PageId of the allocated page, or NULL_PAGE_ID if none could be allocated

Implements Segment.

Definition at line 91 of file DynamicDelegatingSegment.cpp.

References delegateSegment.

Deallocates a range of pages allocated from this segment.

Some segment implementations may impose restrictions on the range (e.g. individual pages only, entire segment truncation only, start-ranges, or end-ranges). The interpretation of the range may also vary by segment (e.g. for a LINEAR_ALLOCATION segment, it's a simple linear PageId range, while for a RANDOM_ALLOCATION segment, successors could be used).

Depending on the circumstances, it may be the responsibility of the segment to discard the corresponding blocks from the cache. The details vary by segment implementation.

Parameters:

Implements Segment.

Definition at line 103 of file DynamicDelegatingSegment.cpp.

References delegateSegment.

00106 { 00107 SharedSegment pDelegateSegment = delegateSegment.lock(); 00108 pDelegateSegment->deallocatePageRange(startPageId,endPageId); 00109 }

Determines whether a page can be updated in-place, and if so, prepares the page for update.

Parameters:

Returns:

NULL_PAGE_ID if the page can be updated in place; otherwise, the pageId of the page that should be used when updates are made to the page

Reimplemented from Segment.

Definition at line 186 of file DynamicDelegatingSegment.cpp.

References delegateSegment.

00189 { 00190 SharedSegment pDelegateSegment = delegateSegment.lock(); 00191 return pDelegateSegment->updatePage(pageId, needsTranslation); 00192 }

Returns the mapped page listener corresponding to a page.

Parameters:

Returns:

segment corresponding to mapped page listener

Reimplemented from Segment.

Definition at line 194 of file DynamicDelegatingSegment.cpp.

References delegateSegment.

00196 { 00197
00198
00199 SharedSegment pDelegateSegment = delegateSegment.lock(); 00200 return pDelegateSegment->getMappedPageListener(blockId); 00201 }

| bool DynamicDelegatingSegment::isWriteVersioned | ( | | ) | [virtual] | | ----------------------------------------------- | - | | - | ----------- |

Receives notification from CacheImpl as soon as a page is mapped, before any I/O is initiated to retrieve the page contents.

Called with the page mutex held, so the implementation must take care to avoid deadlock.

Parameters:

Reimplemented from MappedPageListener.

Definition at line 123 of file DynamicDelegatingSegment.cpp.

References delegateSegment.

Receives notification from CacheImpl the first time a page becomes dirty after it has been mapped (but before the contents have changed).

Allows some logging action to be taken; for example, making a backup copy of the unmodified page contents. Note that when called for a newly allocated page, the page contents are invalid. Because it is implied that the calling thread already has an exclusive lock on the page, no cache locks are held when called.

Parameters:

Reimplemented from MappedPageListener.

Definition at line 141 of file DynamicDelegatingSegment.cpp.

References delegateSegment.

Receives notification from CacheImpl just before a dirty page is flushed to disk.

Allows some logging action to be taken; for example, flushing corresponding write-ahead log pages, or storing a checksum in the page header. Called with the page mutex held, so the implementation must take care to avoid deadlock.

Parameters:

Reimplemented from MappedPageListener.

Definition at line 147 of file DynamicDelegatingSegment.cpp.

References delegateSegment.

| void Segment::setUsablePageSize | ( | uint | | ) | [protected, inherited] | | ------------------------------- | - | ----------------------------------------------------------------- | | - | ------------------------ |

| SharedCache Segment::getCache | ( | | ) | const [inline, inherited] | | --------------------------------------------------------------------------------------- | - | | - | --------------------------- |

| uint Segment::getFullPageSize | ( | | ) | const [inherited] | | ------------------------------------------------------------------------------------------ | - | | - | ------------------- |

| uint Segment::getUsablePageSize | ( | | ) | const [inline, inherited] | | -------------------------------------------------------------------------------------------- | - | | - | --------------------------- |

| void Segment::initForUse | ( | | ) | [virtual, inherited] | | ------------------------ | - | | - | ---------------------- |

Returns:

tracing segment associated with this segment if tracing is turned on; otherwise, returns the segment itself

Definition at line 50 of file Segment.cpp.

References Segment::pTracingSegment.

Referenced by VersionedRandomAllocationSegment::allocateAllocNodes(), RandomAllocationSegment::allocateFromExtent(), RandomAllocationSegment::allocateFromNewExtent(), RandomAllocationSegment::allocatePageId(), VersionedRandomAllocationSegment::backupAllocationNodes(), VersionedRandomAllocationSegment::chainPageEntries(), SnapshotRandomAllocationSegment::commitChanges(), VersionedRandomAllocationSegment::copyPageEntryFromTemp(), VersionedRandomAllocationSegment::copyPageEntryToTemp(), RandomAllocationSegmentBase::deallocatePageId(), VersionedRandomAllocationSegment::findAllocPageIdForRead(), RandomAllocationSegmentBase::format(), RandomAllocationSegmentBase::formatPageExtentsTemplate(), RandomAllocationSegmentBase::freePageEntryTemplate(), RandomAllocationSegment::getExtAllocPageIdForRead(), VersionedRandomAllocationSegment::getOldestTxnId(), VersionedRandomAllocationSegment::getOldPageIds(), RandomAllocationSegmentBase::getPageEntryCopyTemplate(), RandomAllocationSegment::getSegAllocPageIdForRead(), VersionedRandomAllocationSegment::getTempAllocNodePage(), Segment::getTracingListener(), VersionedRandomAllocationSegment::locateDataPages(), VersionedRandomAllocationSegment::restoreFromBackup(), SnapshotRandomAllocationSegment::rollbackChanges(), RandomAllocationSegment::setPageSuccessor(), VersionedRandomAllocationSegment::updateExtentEntry(), and VersionedRandomAllocationSegment::validateFreePageCount().

00051 { 00052 SharedSegment sharedPtr = pTracingSegment.lock(); 00053 if (sharedPtr && sharedPtr.get()) { 00054 return sharedPtr; 00055 } else { 00056 return shared_from_this(); 00057 } 00058 }

Sets the tracing segment associated with this segment.

Parameters:

Definition at line 60 of file Segment.cpp.

References Segment::pTracingSegment.

Constructs a linear PageId based on a linear page number.

Definition at line 348 of file Segment.h.

Referenced by RandomAllocationSegmentBase::allocateFromLockedExtentTemplate(), ScratchSegment::allocatePageId(), LinearViewSegment::allocatePageId(), LinearDeviceSegment::allocatePageId(), CircularSegment::allocatePageId(), RandomAllocationSegmentBase::getExtentAllocPageId(), VersionedRandomAllocationSegment::getOldPageIds(), RandomAllocationSegmentBase::getSegAllocPageId(), Database::init(), VersionedRandomAllocationSegment::locateDataPages(), SegmentTestBase::lockPage(), SegmentTestBase::prefetchPage(), SegPageIterTest::testBoundedIter(), SegPageEntryIterTest::testBoundedIter(), ScratchSegment::translateBlockId(), LinearViewSegment::translateBlockId(), LinearDeviceSegment::translateBlockId(), CircularSegment::translateBlockId(), and CircularSegment::translatePageId().

00349 { 00350 return PageId(iPage); 00351 }

Obtains the linear page number from a linear PageId.

Definition at line 353 of file Segment.h.

References opaqueToInt().

Referenced by CircularSegment::CircularSegment(), LinearDeviceSegment::deallocatePageRange(), CircularSegment::deallocatePageRange(), Segment::isLinearPageIdAllocated(), CircularSegment::isPageIdAllocated(), SegmentTestBase::lockPage(), SegInputStream::readPrevBuffer(), Segment::setLinearPageSuccessor(), RandomAllocationSegmentBase::splitPageId(), CircularSegment::translateBlockId(), ScratchSegment::translatePageId(), LinearViewSegment::translatePageId(), LinearDeviceSegment::translatePageId(), CircularSegment::translatePageId(), and LinearViewSegment::updatePage().

Receives notification that a page has been flushed during a checkpoint.

Also determines if the listener on the page needs to be reset.

Note that if the page listener is reset, that page may not be unmapped during a CHECKPOINT_FLUSH_AND_UNMAP checkpoint call.

This method should be called immediately after the page flush has completed while the checkpoint is still in progress.

Parameters:

Returns:

NULL if the listener on the page does not need to be reset; otherwise, returns the listener that the page should be reset to

Reimplemented in SnapshotRandomAllocationSegment, and TracingSegment.

Definition at line 62 of file MappedPageListener.cpp.

00064 { 00065 return NULL; 00066 }

| bool ClosableObject::isClosed | ( | | ) | const [inline, inherited] | | ----------------------------- | - | | - | --------------------------- |

Returns:

whether the object has been closed

Definition at line 58 of file ClosableObject.h.

| void ClosableObject::close | ( | | ) | [inherited] | | -------------------------- | - | | - | ------------- |

Closes this object, releasing any unallocated resources.

Reimplemented in CollectExecStream, CorrelationJoinExecStream, LcsClusterAppendExecStream, and LcsClusterReplaceExecStream.

Definition at line 39 of file ClosableObject.cpp.

References ClosableObject::closeImpl(), and ClosableObject::needsClose.

Referenced by CacheImpl< PageT, VictimPolicyT >::allocatePages(), LcsRowScanBaseExecStream::closeImpl(), ExecStreamGraphImpl::closeImpl(), FlatFileBuffer::open(), ClosableObjectDestructor::operator()(), and Segment::~Segment().

Member Data Documentation

Definition at line 41 of file DynamicDelegatingSegment.h.

Referenced by allocatePageId(), canFlushPage(), closeImpl(), deallocatePageRange(), delegatedCheckpoint(), DynamicDelegatingSegment(), ensureAllocatedSize(), getAllocatedSizeInPages(), getAllocationOrder(), getDelegateSegment(), getMappedPageListener(), getNumPagesExtended(), getNumPagesOccupiedHighWater(), getPageSuccessor(), isPageIdAllocated(), isWriteVersioned(), notifyAfterPageFlush(), notifyAfterPageRead(), notifyBeforePageFlush(), notifyPageDirty(), notifyPageMap(), notifyPageUnmap(), setDelegatingSegment(), setPageSuccessor(), translateBlockId(), translatePageId(), and updatePage().

Cache managing pages of this segment.

Definition at line 62 of file Segment.h.

Referenced by VersionedRandomAllocationSegment::allocateAllocNodes(), RandomAllocationSegmentBase::allocateFromExtentTemplate(), RandomAllocationSegmentBase::allocateFromNewExtentTemplate(), RandomAllocationSegmentBase::allocatePageIdFromSegment(), VersionedRandomAllocationSegment::backupAllocationNodes(), VersionedRandomAllocationSegment::chainPageEntries(), VersionedRandomAllocationSegment::copyPageEntryFromTemp(), VersionedRandomAllocationSegment::copyPageEntryToTemp(), RandomAllocationSegmentBase::deallocatePageId(), VersionedRandomAllocationSegment::deallocateSinglePage(), VersionedRandomAllocationSegment::deferDeallocation(), VersionedSegment::delegatedCheckpoint(), SnapshotRandomAllocationSegment::delegatedCheckpoint(), Segment::delegatedCheckpoint(), RandomAllocationSegmentBase::format(), RandomAllocationSegmentBase::formatPageExtentsTemplate(), RandomAllocationSegmentBase::freePageEntryTemplate(), Segment::getCache(), Segment::getFullPageSize(), VersionedRandomAllocationSegment::getOldestTxnId(), VersionedRandomAllocationSegment::getOldPageIds(), RandomAllocationSegmentBase::getPageEntryCopyTemplate(), VersionedRandomAllocationSegment::getTempAllocNodePage(), VersionedRandomAllocationSegment::initPageEntry(), VersionedRandomAllocationSegment::locateDataPages(), VersionedSegment::notifyPageDirty(), VersionedSegment::recover(), VersionedRandomAllocationSegment::restoreFromBackup(), RandomAllocationSegmentBase::setPageSuccessorTemplate(), RandomAllocationSegmentBase::tallySegAllocNodePages(), VersionedRandomAllocationSegment::uncommittedDeallocation(), VersionedRandomAllocationSegment::updateExtentEntry(), VersionedRandomAllocationSegment::updatePageEntry(), VersionedRandomAllocationSegment::updateTempPageEntry(), and VersionedRandomAllocationSegment::validateFreePageCount().

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

• /home/pub/open/dev/fennel/segment/DynamicDelegatingSegment.h
• /home/pub/open/dev/fennel/segment/DynamicDelegatingSegment.cpp

Generated on Mon Jun 22 04:00:30 2009 for Fennel by 1.5.1