DbiValidityRec Class Reference

Concept A concrete data type corresponding to a single row in an auxillary validity range database table. Purpose To resolve ambiguities in the case of multiple matches to a query and to record results of validity range trimming due to neighbouring database entries. More...

#include <DbiValidityRec.h>

Inheritance diagram for DbiValidityRec:

List of all members.

Public Member Functions
	DbiValidityRec (Int_t dbNo=-1, Bool_t isGap=kTRUE)
	DbiValidityRec (const DbiValidityRec &from)
	DbiValidityRec (const VldRange &range, Dbi::Task task, Int_t aggNo, UInt_t seqNo, Int_t dbNo=-1, Bool_t isGap=kFALSE, VldTimeStamp time=VldTimeStamp())
virtual	~DbiValidityRec ()
virtual DbiTableRow *	CreateTableRow () const
Int_t	GetAggregateNo () const
VldTimeStamp	GetCreationDate () const
UInt_t	GetDbNo () const
VldTimeStamp	GetInsertDate () const
Dbi::Task	GetTask () const
std::string	GetL2CacheName () const
UInt_t	GetSeqNo () const
const DbiTableProxy *	GetTableProxy () const
const VldRange &	GetVldRange () const
Bool_t	HasExpired (const DbiValidityRec &other) const
Bool_t	HasExpired (const VldContext &vc, const Dbi::Task &task) const
Bool_t	IsCompatible (const VldContext &vc, const Dbi::Task &task) const
Bool_t	IsGap () const
void	AndTimeWindow (const VldTimeStamp &start, const VldTimeStamp &end)
void	SetAggregateNo (Int_t aggNo)
void	SetDbNo (Int_t dbNo)
void	SetTableProxy (const DbiTableProxy *tp)
void	SetTimeWindow (const VldTimeStamp &start, const VldTimeStamp &end)
void	SetVldRange (const VldRange &range)
void	Trim (const VldTimeStamp &queryTime, const DbiValidityRec &other)
virtual void	Fill (DbiResultSet &rs, const DbiValidityRec *vrec)
virtual void	Store (DbiOutRowStream &ors, const DbiValidityRec *vrec) const
void	Streamer (DbiBinaryFile &file)
Static Public Member Functions
std::string	GetL2CacheName (UInt_t seqLo, UInt_t seqHi, VldTimeStamp ts)
Private Attributes
Int_t	fAggregateNo
VldTimeStamp	fCreationDate
	Creation date.
Int_t	fDbNo
	Cascade no. of source db =-1 unknown.
VldTimeStamp	fInsertDate
	Insertion date.
Bool_t	fIsGap
	kTRUE if corresponds to a gap.
Dbi::Task	fTask
	Task number.
Int_t	fSeqNo
	Sequence number or 0 if compound.
const DbiTableProxy *	fTableProxy
	DbiTableProxy that filled this (if any).
VldRange	fVldRange
	Validity range of record.

---

Detailed Description

Concept A concrete data type corresponding to a single row in an auxillary validity range database table. Purpose To resolve ambiguities in the case of multiple matches to a query and to record results of validity range trimming due to neighbouring database entries.

Id

DbiValidityRec.h,v 1.18 2006/08/08 10:51:32 west Exp

DatabaseInterface

Contact: n.west1@physics.ox.ac.uk

Definition at line 40 of file DbiValidityRec.h.

---

Constructor & Destructor Documentation

DbiValidityRec::DbiValidityRec (  Int_t  dbNo = -1, Bool_t  isGap = kTRUE )

Definition at line 120 of file DbiValidityRec.cxx. References LEA_CTOR, and MSG. 00120 : 00121 00122 fAggregateNo(-2), 00123 fDbNo(dbNo), 00124 fIsGap(isGap), 00125 fTask(0), 00126 fSeqNo(0), 00127 fTableProxy(0) 00128 { 00129 // 00130 // 00131 // Purpose: Default constructor 00132 // 00133 // Arguments:. 00134 // dbNo in Cascade no. of database holding record. 00135 // isGap in = kTRUE if a gap. 00136 // 00137 // Return: n/a 00138 // 00139 // Contact: N. West 00140 // 00141 // Specification:- 00142 // ============= 00143 // 00144 // o Create ValidityRec. 00145 00146 00147 // Program Notes:- 00148 // ============= 00149 00150 // None. 00151 00152 LEA_CTOR //Leak Checker 00153 00154 MSG("Dbi", Msg::kVerbose) << "Creating DbiValidityRec" << endl; 00155 } //.....................................................................

DbiValidityRec::DbiValidityRec (  const DbiValidityRec &  from  )

Definition at line 158 of file DbiValidityRec.cxx. References LEA_CTOR, and MSG. : DbiTableRow(from) { // // // Purpose: Copy constructor // // Arguments: // from in Object to be copied from. // // Return: n/a // // Contact: N. West // // Specification:- // ============= // // o Create ValidityRec. // Program Notes:- // ============= // Explicit just for leak checking. LEA_CTOR //Leak Checker MSG("Dbi", Msg::kVerbose) << "Creating DbiValidityRec" << endl; *this = from; }

DbiValidityRec::DbiValidityRec (  const VldRange &  range, Dbi::Task  task, Int_t  aggNo, UInt_t  seqNo, Int_t  dbNo = -1, Bool_t  isGap = kFALSE, VldTimeStamp  time = VldTimeStamp() )

Definition at line 191 of file DbiValidityRec.cxx. References LEA_CTOR, and MSG. : fAggregateNo(aggNo), fCreationDate(time), fDbNo(dbNo), fIsGap(isGap), fTask(task), fSeqNo(seqNo), fTableProxy(0), fVldRange(range) { // // // Purpose: Constructor from components // // Arguments: // range in component range // task in component task // aggNo in component aggregate number // seqNo in component sequence number // dbNo in Cascade no. of database holding record. // isGap in = kTRUE if a gap. // // // // // Return: n/a // // Contact: N. West // // Specification:- // ============= // // o Create ValidityRec. // Program Notes:- // ============= // None. LEA_CTOR //Leak Checker MSG("Dbi", Msg::kVerbose) << "Creating DbiValidityRec" << endl; }

DbiValidityRec::~DbiValidityRec (   )  [virtual]

Definition at line 244 of file DbiValidityRec.cxx. References LEA_DTOR, and MSG. { // // // Purpose: Destructor // // Arguments: // None. // // Return: n/a // // Contact: N. West // // Specification:- // ============= // // o Destroy ValidityRec. // Program Notes:- // ============= // None. LEA_DTOR //Leak Checker MSG("Dbi", Msg::kVerbose) << "Destroying DbiValidityRec" << endl; }

---

Member Function Documentation

void DbiValidityRec::AndTimeWindow (  const VldTimeStamp &  start, const VldTimeStamp &  end )

Definition at line 86 of file DbiValidityRec.cxx. References fVldRange, VldRange::GetTimeEnd(), VldRange::GetTimeStart(), and SetTimeWindow(). Referenced by DbiResultAgg::DbiResultAgg(). { // // // Purpose: And in supplied start and end times. // // Arguments: // startOther in Start time to be ANDed in. // endOther in End time to be ANDed in. // // Return: None. // // Contact: N. West // // Specification:- // ============= // // o Trim time windown on current record to be the overlap (and) // with the supplied time window. // Program Notes:- // ============= // None. VldTimeStamp start = fVldRange.GetTimeStart(); VldTimeStamp end = fVldRange.GetTimeEnd(); SetTimeWindow( start > startOther ? start : startOther, end < endOther ? end : endOther ); }

virtual DbiTableRow* DbiValidityRec::CreateTableRow (   )  const [inline, virtual]

Implements DbiTableRow. Definition at line 60 of file DbiValidityRec.h. { return new DbiValidityRec; }

void DbiValidityRec::Fill (  DbiResultSet &  rs, const DbiValidityRec *  vrec )  [virtual]

Implements DbiTableRow. Definition at line 275 of file DbiValidityRec.cxx. References VldRange::AsString(), DbiResultSet::CurRowNum(), fAggregateNo, fCreationDate, fDbNo, fIsGap, fSeqNo, fTableProxy, fTask, fVldRange, DbiResultSet::GetDbNo(), DbiResultSet::GetTableProxy(), and MSG. { // // // Purpose: Fill oject from Result Set // // Arguments: // rs in Result Set used to fill object // vrec in =0. If filling other table rows it points // to the associated validity record. // // Return: // // Contact: N. West // // Specification:- // ============= // // o Fill object from current row of Result Set. // Program Notes:- // ============= // None. VldTimeStamp start, end; Int_t detMask, simMask; // Establish source DbiTableProxy and cascade no. fTableProxy = rs.GetTableProxy(); fDbNo = rs.GetDbNo(); // Read data from row. rs >> fSeqNo >> start >> end >> detMask >> simMask >> fTask >> fAggregateNo >> fCreationDate >> fInsertDate; fIsGap = kFALSE; VldRange vr(detMask, simMask, start, end, "From Database"); fVldRange = vr; MSG("Dbi", Msg::kVerbose) << "DbiValidityRec for row " << rs.CurRowNum() << ": " << fVldRange.AsString() << " seq num: " << fSeqNo << " agg no: " << fAggregateNo << " task: " << endl; }

Int_t DbiValidityRec::GetAggregateNo (   )  const [inline, virtual]

Reimplemented from DbiTableRow. Definition at line 62 of file DbiValidityRec.h. Referenced by DbiCache::Adopt(), DbiWriter< T >::CompleteOpen(), DbiValidityRecBuilder::DbiValidityRecBuilder(), DbiConfigSet::Fill(), main(), DbiWriter< T >::operator<<(), DbiConfigStream::operator<<(), PrintTimeCal(), DbiTableProxy::QueryOverlayCreationDate(), DbiCache::Search(), DbiConfigStream::Write(), and WriteTableToCSVFile(). { return fAggregateNo; }

VldTimeStamp DbiValidityRec::GetCreationDate (   )  const [inline]

Definition at line 63 of file DbiValidityRec.h. Referenced by DbiWriter< T >::CompleteOpen(), DbiResultNonAgg::CreateKey(), DbiResultAgg::CreateKey(), DbiValidityRecBuilder::DbiValidityRecBuilder(), DbiValidityRecBuilder::GetL2CacheName(), GetL2CacheName(), DbmModule::Import(), CoilTools::LocalQuery(), main(), DbiWriter< T >::Open(), PrintTimeCal(), DbiResultNonAgg::Satisfies(), DbiLogEntry::Write(), and WriteTableToCSVFile(). { return fCreationDate; }

UInt_t DbiValidityRec::GetDbNo (   )  const [inline]

Definition at line 64 of file DbiValidityRec.h. Referenced by DbiResultAgg::DbiResultAgg(), DbiSqlValPacket::DbiSqlValPacket(), PulserDBModule::DeleteGC(), DbmModule::ExportTable(), main(), PrintTimeCal(), and DbiTableProxy::Query(). { return fDbNo; }

VldTimeStamp DbiValidityRec::GetInsertDate (   )  const [inline]

Definition at line 65 of file DbiValidityRec.h. Referenced by DbmModule::ExportTable(), main(), PrintTimeCal(), and WriteTableToCSVFile(). { return fInsertDate; }

std::string DbiValidityRec::GetL2CacheName (  UInt_t  seqLo, UInt_t  seqHi, VldTimeStamp  ts )  [static]

Definition at line 345 of file DbiValidityRec.cxx. References VldTimeStamp::AsString(). { // // // Purpose: Return the associated Level 2 Cache Name. // // Specification:- // ============= // // o For unaggregated queries name format: <Seqno>_<CreationDate> // // o For aggregated queries name format: <LowSeqno>_<HighSeqNo>_<MaxCreationDate> // Program Notes:- // ============= // The static routine centralises the definition of cache names both for // DbiValidityRec and DbiValidityRecBuilder. ostringstream oss; oss << seqLo << "_"; if ( seqLo != seqHi ) oss << seqHi << "_"; oss << ts.AsString("s"); std::string str(oss.str()); // Convert white space to underscore. int i = str.size(); while ( i-- ) if ( str[i] == ' ' ) str[i] = '_'; return str; }

std::string DbiValidityRec::GetL2CacheName (   )  const

Definition at line 328 of file DbiValidityRec.cxx. References GetCreationDate(), and GetSeqNo(). Referenced by DbiValidityRecBuilder::GetL2CacheName(), and DbiTableProxy::Query(). { // // // Purpose: Return the associated Level 2 Cache Name. // // Specification:- // ============= // // o See GetL2CacheName(UInt_t seqLo, UInt_t seqHi, VldTimeStamp ts); return DbiValidityRec::GetL2CacheName(this->GetSeqNo(), this->GetSeqNo(), this->GetCreationDate()); }

UInt_t DbiValidityRec::GetSeqNo (   )  const [inline]

Definition at line 68 of file DbiValidityRec.h. Referenced by DbiResult::BuildLookUpTable(), CheckGC::checklin(), CoilTools::CoilCurrentLimits(), DbiResultNonAgg::CreateKey(), DbiResultAgg::CreateKey(), DbiResultAgg::DbiResultAgg(), DbiSqlValPacket::DbiSqlValPacket(), DbiValidityRecBuilder::DbiValidityRecBuilder(), PulserDBModule::DeleteGC(), dump_peds(), DbmModule::ExportTable(), DbuDaqConfigFilesText::Fill(), UgliDbiStripStruct::FormatToOStream(), UgliDbiStrip::FormatToOStream(), UgliDbiSteelPln::FormatToOStream(), UgliDbiScintPlnStruct::FormatToOStream(), UgliDbiScintPln::FormatToOStream(), UgliDbiScintMdlStruct::FormatToOStream(), UgliDbiScintMdl::FormatToOStream(), UgliDbiGeometry::FormatToOStream(), DbiValidityRecBuilder::GetL2CacheName(), GetL2CacheName(), DbiValRecSet::GetTableRowBySeqNo(), DbmModule::GlobaliseSeqNo(), CoilTools::LocalQuery(), DbmLogFile::LogRec(), main(), PrintTimeCal(), DbiTableProxy::Query(), DbiTableProxy::RestoreFromL2Cache(), DbiResultNonAgg::Satisfies(), MBSpillAccessor::SeekClosest(), BDSpillAccessor::SeekClosest(), PlotPeds::Update(), and WriteTableToCSVFile(). { return fSeqNo; }

const DbiTableProxy* DbiValidityRec::GetTableProxy (   )  const [inline]

Definition at line 69 of file DbiValidityRec.h. Referenced by DbiSqlValPacket::DbiSqlValPacket(), DbmModule::ExportTable(), DbmLogFile::LogRec(), DbiWriter< T >::Open(), DbiTableProxy::Query(), and DbiConfigStream::Write(). { return fTableProxy; }

Dbi::Task DbiValidityRec::GetTask (   )  const [inline]

Definition at line 66 of file DbiValidityRec.h. Referenced by CheckGC::checklin(), DbiWriter< T >::CompleteOpen(), PulserTimePlotter::CreateGraph(), DbiLogEntry::Fill(), HasExpired(), DbmModule::LogEntry(), main(), DbiResultPtr< T >::NextQuery(), PrintTimeCal(), DbiTableProxy::QueryOverlayCreationDate(), DbiLogEntry::Write(), and WriteTableToCSVFile(). { return fTask; }

const VldRange& DbiValidityRec::GetVldRange (   )  const [inline]

Definition at line 70 of file DbiValidityRec.h. Referenced by CountPot::Ana(), BfldCache::BfldCache(), CheckGC::checklin(), CoilTools::CoilCurrentLimits(), DbiWriter< T >::CompleteOpen(), PulserTimePlotter::CreateGraph(), SpillServerMonFinder::DataIsAvailable(), DbiResultAgg::DbiResultAgg(), DbiValidityRecBuilder::DbiValidityRecBuilder(), PhotonStatSummarizer::DoesTableExist(), MuonDriftCalScheme::DoReset(), LIPlexMaps::DriftWithTime(), dump_peds(), CountPot::EndJob(), HvStatusFinder::ExtendedQuery(), UgliDbiStripStruct::Fill(), UgliDbiStrip::Fill(), UgliDbiSteelPln::Fill(), UgliDbiScintPlnStruct::Fill(), UgliDbiScintPln::Fill(), UgliDbiScintMdlStruct::Fill(), UgliDbiScintMdl::Fill(), PulserRefDriftPin::Fill(), PulserRawGainPin::Fill(), PulserRawDriftPin::Fill(), PulserGainPin::Fill(), PulserDriftPin::Fill(), PlexVetoShieldMuxToMdl::Fill(), DbuVaChipSpars::Fill(), DbuVaChipPeds::Fill(), DbuSubRunSummary::Fill(), DbuRunSummary::Fill(), DbuDaqFileSummary::Fill(), DbiLogEntry::Fill(), BfldDbiPlaneMap::Fill(), BfieldCoilCurrent::Fill(), CountPot::FillMBPOT(), SpillTimeFinder::FindClosestEntries(), SpillServerMonFinder::FindClosestEntries(), Summarizer::FindNextContext(), FitNdNonlinQuad(), CoilTools::GetLast(), HasExpired(), HvStatusFinder::LocalQuery(), CoilTools::LocalQuery(), DbmModule::LogEntry(), main(), PlotPeds::Next(), PlotAllPeds::Next(), FabPlnInstallLookup::NextInstall(), DbiResultPtr< T >::NextQuery(), PlotAllPeds::Prev(), PrintTimeCal(), DbiTableProxy::QueryOverlayCreationDate(), LIPlexMaps::ReadDbGainAverage(), SimPmtM64CrosstalkTable::Reset(), RangeLookupTable::Reset(), PhotonLookupTable::Reset(), PulserGainFit::RunNearFarFits(), PulserGainFit::RunPinFits(), MBSpillAccessor::SeekClosest(), BDSpillAccessor::SeekClosest(), DbiResultPtr< T >::SetContext(), BDSwicPedAccessor::SetSpillTime(), Trim(), UgliGeometry::TrimVldRange(), Plexus::TrimVldRange(), GeoGeometry::TrimVldRange(), PlotPeds::Update(), DbiLogEntry::Write(), WriteTableToCSVFile(), and PulserDBModule::WriteTempGC(). { return fVldRange;}

Bool_t DbiValidityRec::HasExpired (  const VldContext &  vc, const Dbi::Task &  task )  const

Definition at line 418 of file DbiValidityRec.cxx. References VldContext::GetDetector(), VldRange::GetDetectorMask(), VldContext::GetSimFlag(), VldRange::GetSimMask(), GetTask(), VldRange::GetTimeEnd(), VldContext::GetTimeStamp(), VldRange::GetTimeStart(), and GetVldRange(). { // // // Purpose: See if validity record has expired i.e. is compatible with // this context query except for date. // // Arguments: // vc in Context of query // task in Task of query // // // Contact: N. West // Program Notes:- // ============= // This method is used by DbiResult to identify when ready for // purging. VldTimeStamp ts = vc.GetTimeStamp(); const VldRange& vr = this->GetVldRange(); return ( task == this->GetTask() && ( vc.GetDetector() & vr.GetDetectorMask() ) && ( vc.GetSimFlag() & vr.GetSimMask() ) && ( ts >= vr.GetTimeEnd() || ts < vr.GetTimeStart() ) ); }

Bool_t DbiValidityRec::HasExpired (  const DbiValidityRec &  other  )  const

Definition at line 379 of file DbiValidityRec.cxx. References fTask, fVldRange, VldRange::GetDetectorMask(), VldRange::GetSimMask(), GetTask(), VldRange::GetTimeEnd(), VldRange::GetTimeStart(), and GetVldRange(). Referenced by DbiResult::CanDelete(), and DbiResult::Satisfies(). { // // // Purpose: See if validity record has expired i.e. is compatible with // this one except for date. // // Arguments: // other in Other DbiValidityRec to be compared with // // Return: // // Contact: N. West // // Specification:- // ============= // // o See if validity record has expired i.e. is compatible with // this one except for date. // Program Notes:- // ============= // This method is used by DbiCache to select candidates for // purging. const VldRange& otherVR =other.GetVldRange(); return ( other.GetTask() == fTask && ( otherVR.GetDetectorMask() & fVldRange.GetDetectorMask() ) && ( otherVR.GetSimMask() & fVldRange.GetSimMask() ) && ( otherVR.GetTimeStart() >= fVldRange.GetTimeEnd() || otherVR.GetTimeEnd() <= fVldRange.GetTimeStart() ) ); }

Bool_t DbiValidityRec::IsCompatible (  const VldContext &  vc, const Dbi::Task &  task )  const

Definition at line 454 of file DbiValidityRec.cxx. References VldContext::AsString(), VldRange::AsString(), fTask, fVldRange, VldRange::IsCompatible(), and MSG. Referenced by DbiResult::Satisfies(). { // // // Purpose: See if result is compatible with query. // // Arguments: // vc in Context of new query // task in Task of new query // // Return: // // Contact: N. West // // Specification:- // ============= // // o See if result is compatible with query. // Program Notes:- // ============= // None. MSG("Dbi",Msg::kDebug) << " DbiValidityRec::IsCompatible : tasks:" << task << "," << fTask << " is compat: " << fVldRange.IsCompatible(vc) << endl << " range " << fVldRange.AsString() << endl << " context " << vc.AsString() << endl; return task == fTask && fVldRange.IsCompatible(vc); }

Bool_t DbiValidityRec::IsGap (   )  const [inline]

Definition at line 76 of file DbiValidityRec.h. Referenced by SpillTimeFinder::DataIsAvailable(), SpillServerMonFinder::DataIsAvailable(), DbiResultAgg::DbiResultAgg(), DbiValidityRecBuilder::DbiValidityRecBuilder(), HvStatusFinder::ExtendedQuery(), CoilTools::ExtendedQuery(), DbiValidityRecBuilder::GetL2CacheName(), DbiTableProxy::Query(), DbiResultAgg::Streamer(), and Trim(). { return fIsGap; }

void DbiValidityRec::SetAggregateNo (  Int_t  aggNo  )  [inline]

Definition at line 83 of file DbiValidityRec.h. References fAggregateNo. Referenced by DbiResultAgg::DbiResultAgg(), and DbiConfigStream::Write(). { fAggregateNo = aggNo; }

void DbiValidityRec::SetDbNo (  Int_t  dbNo  )  [inline]

Definition at line 84 of file DbiValidityRec.h. References fDbNo. Referenced by DbiConfigStream::DbiConfigStream(), and DbiValidityRecBuilder::DbiValidityRecBuilder(). { fDbNo = dbNo; }

void DbiValidityRec::SetTableProxy (  const DbiTableProxy *  tp  )  [inline]

Definition at line 85 of file DbiValidityRec.h. References fTableProxy. Referenced by DbiConfigStream::DbiConfigStream(). { fTableProxy = tp; }

void DbiValidityRec::SetTimeWindow (  const VldTimeStamp &  start, const VldTimeStamp &  end )

Definition at line 489 of file DbiValidityRec.cxx. References fVldRange, VldRange::GetDataSource(), VldRange::GetDetectorMask(), and VldRange::GetSimMask(). Referenced by AndTimeWindow(), and Trim(). { // // // Purpose: Set supplied start and end times. // // Arguments: // start in Start time to be set, // end in End time to be set. // // Return: None. // // Contact: N. West // // Specification:- // ============= // // o Set time windown on current record. // Program Notes:- // ============= // The method here is rather clumsy, but I don't know of anything // better! VldRange range(fVldRange.GetDetectorMask(), fVldRange.GetSimMask(), start, end, fVldRange.GetDataSource() ); fVldRange = range; }

void DbiValidityRec::SetVldRange (  const VldRange &  range  )  [inline]

Definition at line 88 of file DbiValidityRec.h. References fVldRange. Referenced by DbiConfigStream::DbiConfigStream(), and DbiValidityRecBuilder::DbiValidityRecBuilder(). { fVldRange=range;}

void DbiValidityRec::Store (  DbiOutRowStream &  ors, const DbiValidityRec *  vrec )  const [virtual]

Reimplemented from DbiTableRow. Definition at line 525 of file DbiValidityRec.cxx. References fAggregateNo, fCreationDate, fSeqNo, fTask, fVldRange, VldRange::GetDetectorMask(), VldRange::GetSimMask(), VldRange::GetTimeEnd(), and VldRange::GetTimeStart(). Referenced by DbiSqlValPacket::Recreate(). { // // // Purpose: Stream object to output row stream // // Arguments: // ors in Output row stream. // vrec in =0. If filling other table rows it points // to the associated validity record. // // Return: // // Contact: N. West // // Specification:- // ============= // // o Stream object to output row stream. // Program Notes:- // ============= // None. // Write data to row. ors << fSeqNo << fVldRange.GetTimeStart() << fVldRange.GetTimeEnd() << fVldRange.GetDetectorMask() << fVldRange.GetSimMask() << fTask << fAggregateNo << fCreationDate << fInsertDate; }

void DbiValidityRec::Streamer (  DbiBinaryFile &  file  )

Definition at line 564 of file DbiValidityRec.cxx. References fAggregateNo, fCreationDate, fDbNo, fInsertDate, fIsGap, fSeqNo, fTableProxy, fTask, DbiBinaryFile::IsReading(), and DbiBinaryFile::IsWriting(). Referenced by DbiResult::Streamer(). { // // // Purpose: I/O to binary file // // Program Notes:- // ============= // Don't store the pointer fTableProxy (don't want to get into storing // pointers!); the DbiCache will fix it up on input if ( file.IsReading() ) { file >> fAggregateNo >> fCreationDate >> fDbNo >> fInsertDate >> fIsGap >> fTask >> fSeqNo >> fVldRange; fTableProxy = 0; } else if ( file.IsWriting() ) { file << fAggregateNo << fCreationDate << fDbNo << fInsertDate << fIsGap << fTask << fSeqNo << fVldRange; } }

void DbiValidityRec::Trim (  const VldTimeStamp &  queryTime, const DbiValidityRec &  other )

Definition at line 600 of file DbiValidityRec.cxx. References fAggregateNo, fVldRange, VldRange::GetTimeEnd(), VldRange::GetTimeStart(), GetVldRange(), IsGap(), and SetTimeWindow(). Referenced by DbiValidityRecBuilder::DbiValidityRecBuilder(). { // // // Purpose: Trim this validity record so that represents // best validity record for query. // // Arguments: // queryTime in Time of query // other in DbiValidity record satisfying query // // Return: None. // // Contact: N. West // // Specification:- // ============= // // o Update this validity record so that it remains the best // validity record taking into account the supplied record. // Program Notes:- // ============= // This is the function that deal with validity management. // It takes into account that several validity records may // overlap and that the best one is the one with the latest // creation date that brackets the query date. Other entries // with later creation dates may trim start or end times. // Assumptions:- // =========== // // That entries are submitted in strict descending priority i.e.:- // // 1) Entries for a higher priority database precede those from a // lower priority one. // // 2) Within a database entries are in descending creation date order. // Ignore other records that are either gaps or have wrong // aggregate number. if ( fAggregateNo != other.fAggregateNo || other.IsGap() ) return; // If this record is not a gap then the other record can be ignore // as it is of lower priority. if ( ! IsGap() ) return; VldTimeStamp start = fVldRange.GetTimeStart(); VldTimeStamp end = fVldRange.GetTimeEnd(); VldTimeStamp startOther = other.GetVldRange().GetTimeStart(); VldTimeStamp endOther = other.GetVldRange().GetTimeEnd(); // If entry brackets query date, then use it but with a validity that // is trimmed by the current record. if ( startOther <= queryTime && endOther > queryTime ) { if ( start < startOther ) start = startOther; if ( end > endOther ) end = endOther; *this = other; SetTimeWindow(start,end); } // It doesn't bracket, so use it to trim the window else { if ( endOther <= queryTime ) { if ( start < endOther ) SetTimeWindow(endOther,end); } else if ( startOther > queryTime ) { if ( end > startOther ) SetTimeWindow(start, startOther); } } }

---

Member Data Documentation

Int_t DbiValidityRec::fAggregateNo [private]

Aggregate number or:- -1 Non-aggregated data or multiple aggregates -2 undefined aggregates Definition at line 107 of file DbiValidityRec.h. Referenced by Fill(), SetAggregateNo(), Store(), Streamer(), and Trim().

VldTimeStamp DbiValidityRec::fCreationDate [private]

Creation date. Definition at line 110 of file DbiValidityRec.h. Referenced by Fill(), Store(), and Streamer().

Int_t DbiValidityRec::fDbNo [private]

Cascade no. of source db =-1 unknown. Definition at line 113 of file DbiValidityRec.h. Referenced by Fill(), SetDbNo(), and Streamer().

VldTimeStamp DbiValidityRec::fInsertDate [private]

Insertion date. Definition at line 116 of file DbiValidityRec.h. Referenced by Streamer().

Bool_t DbiValidityRec::fIsGap [private]

kTRUE if corresponds to a gap. Definition at line 119 of file DbiValidityRec.h. Referenced by Fill(), and Streamer().

Int_t DbiValidityRec::fSeqNo [private]

Sequence number or 0 if compound. Definition at line 125 of file DbiValidityRec.h. Referenced by Fill(), Store(), and Streamer().

const DbiTableProxy* DbiValidityRec::fTableProxy [private]

DbiTableProxy that filled this (if any). Definition at line 128 of file DbiValidityRec.h. Referenced by Fill(), SetTableProxy(), and Streamer().

Dbi::Task DbiValidityRec::fTask [private]

Task number. Definition at line 122 of file DbiValidityRec.h. Referenced by Fill(), HasExpired(), IsCompatible(), Store(), and Streamer().

VldRange DbiValidityRec::fVldRange [private]

Validity range of record. Definition at line 131 of file DbiValidityRec.h. Referenced by AndTimeWindow(), Fill(), HasExpired(), IsCompatible(), SetTimeWindow(), SetVldRange(), Store(), and Trim().

---

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

• DbiValidityRec.h
• DbiValidityRec.cxx

---