VersionedSegment.h

Go to the documentation of this file.
00001 /*
00002 // $Id: //open/dev/fennel/segment/VersionedSegment.h#15 $
00003 // Fennel is a library of data storage and processing components.
00004 // Copyright (C) 2005-2009 The Eigenbase Project
00005 // Copyright (C) 2005-2009 SQLstream, Inc.
00006 // Copyright (C) 2005-2009 LucidEra, Inc.
00007 // Portions Copyright (C) 1999-2009 John V. Sichi
00008 //
00009 // This program is free software; you can redistribute it and/or modify it
00010 // under the terms of the GNU General Public License as published by the Free
00011 // Software Foundation; either version 2 of the License, or (at your option)
00012 // any later version approved by The Eigenbase Project.
00013 //
00014 // This program is distributed in the hope that it will be useful,
00015 // but WITHOUT ANY WARRANTY; without even the implied warranty of
00016 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
00017 // GNU General Public License for more details.
00018 //
00019 // You should have received a copy of the GNU General Public License
00020 // along with this program; if not, write to the Free Software
00021 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
00022 */
00023 
00024 #ifndef Fennel_VersionedSegment_Included
00025 #define Fennel_VersionedSegment_Included
00026 
00027 #include "fennel/segment/DelegatingSegment.h"
00028 #include "fennel/synch/SynchObj.h"
00029 #include "fennel/cache/FuzzyCheckpointSet.h"
00030 #include "fennel/common/PseudoUuid.h"
00031 
00032 #include <boost/crc.hpp>
00033 
00034 FENNEL_BEGIN_NAMESPACE
00035 
00036 class WALSegment;
00037 
00044 class FENNEL_SEGMENT_EXPORT VersionedSegment
00045     : public DelegatingSegment
00046 {
00047     friend class SegmentFactory;
00048 
00049     bool inRecovery;
00050     PseudoUuid onlineUuid;
00051     SegVersionNum versionNumber;
00052     PageId oldestLogPageId;
00053     PageId newestLogPageId;
00054     PageId lastCheckpointLogPageId;
00055     StrictMutex mutex;
00056     SharedSegment logSegment;
00057     WALSegment *pWALSegment;
00058     FuzzyCheckpointSet fuzzyCheckpointSet;
00059 
00060     // TODO:  use a 64-bit crc instead
00061     boost::crc_32_type crcComputer;
00062 
00063     PageMap dataToLogMap;
00064 
00065     explicit VersionedSegment(
00066         SharedSegment dataSegment,
00067         SharedSegment logSegment,
00068         PseudoUuid const &onlineUuid,
00069         SegVersionNum versionNumber);
00070 
00071     uint64_t computeChecksum(void const *pPageData);
00072 
00073 public:
00074     virtual ~VersionedSegment();
00075 
00086     void recover(
00087         SharedSegment pDelegatingSegment,
00088         PageId firstLogPageId,
00089         SegVersionNum versionNumber = MAXU);
00090 
00102     void recover(
00103         SharedSegment pDelegatingSegment,
00104         PageId firstLogPageId,
00105         SegVersionNum versionNumber,
00106         PseudoUuid const &onlineUuid);
00107 
00112     void prepareOnlineRecovery();
00113 
00118     PageId getRecoveryPageId() const;
00119 
00124     PageId getOnlineRecoveryPageId() const;
00125 
00133     SegVersionNum getPageVersion(CachePage &page);
00134 
00138     SegVersionNum getVersionNumber() const;
00139 
00143     SharedSegment getLogSegment() const;
00144 
00153     void deallocateCheckpointedLog(CheckpointType checkpointType);
00154 
00155     // implement the Segment interface
00156     virtual void deallocatePageRange(PageId startPageId,PageId endPageId);
00157     virtual void delegatedCheckpoint(
00158         Segment &delegatingSegment,CheckpointType checkpointType);
00159 
00160     // implement the MappedPageListener interface
00161     virtual void notifyPageDirty(CachePage &page,bool bDataValid);
00162     virtual bool canFlushPage(CachePage &page);
00163 };
00164 
00165 FENNEL_END_NAMESPACE
00166 
00167 #endif
00168 
00169 // End VersionedSegment.h

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