TDbiValidityRecBuilder.cxx File Reference

#include "DbiDetector.hxx"
#include "DbiSimFlag.hxx"
#include "TDbiDBProxy.hxx"
#include "TDbiResultSetNonAgg.hxx"
#include "TDbiInRowStream.hxx"
#include "TDbiSimFlagAssociation.hxx"
#include "TDbiValidityRec.hxx"
#include "TDbiValidityRecBuilder.hxx"
#include <TSK_DBI_Log.hxx>
#include <MsgFormat.h>
#include "TVldContext.hxx"

Include dependency graph for TDbiValidityRecBuilder.cxx:

Go to the source code of this file.

Functions
	ClassImp (TDbiValidityRecBuilder) TDbiValidityRecBuilder

---

Function Documentation

ClassImp

(

TDbiValidityRecBuilder

)

Definition at line 16 of file TDbiValidityRecBuilder.cxx.

References DbiSimFlag::AsString(), TDbiSimFlagAssociation::Get(), TDbiValidityRec::GetAggregateNo(), TDbiResultSetNonAgg::GetNumRows(), TVldTimeStamp::GetSec(), TDbiResultSetNonAgg::GetTableRow(), TVldRange::GetTimeEnd(), TDbi::GetTimeGate(), TVldRange::GetTimeStart(), TDbiValidityRec::GetVldRange(), TDbiSimFlagAssociation::Instance(), TDbiValidityRec::IsGap(), TDbiValidityRec::IsHigherPriority(), TDbiValidityRec::SetDbNo(), TDbi::SetTimeGate(), TDbiValidityRec::SetVldRange(), SK_DBI_Debug, SK_DBI_Log, SK_DBI_Trace, SK_DBI_Verbose, SK_DBI_Warn, and TDbiValidityRec::Trim().

                : ctors, dtor, operators then in alphabetical order.

//.....................................................................

TDbiValidityRecBuilder::TDbiValidityRecBuilder(const TDbiDBProxy& proxy,
                                             const TVldContext& vc,
                                             const TDbi::Task& task,
                                             Int_t selectDbNo     /* Default: -1 */,
                                             Bool_t findFullTimeWindow /* Default: true*/
                                             ):
fIsExtendedContext(kFALSE),
fTask(task)
{
//
//  Purpose:  Constructor for specific context queries.
//
//  Arguments:
//    proxy        in    Database proxy for this table.
//    vc           in    The Validity Context for the query.
//    task         in    The task of the query.
//    selectDbNo   in    If >=0 only look in selected DB.
//    findFullTimeWindow
//                 in    Attempt to find full validity of query
//                        i.e beyond TDbi::GetTimeGate
//
//  Return:    n/a
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Create ValidityRecBuilder by applying a validity query to
//    the database table and building a set of TDbiValidityRec
//    objects from the resulting TDbiInRowStream.
//
// o  Try each member of the cascade in turn until a query succeeds or the
//    cascade is exhausted.
//
// o  For each member of the cascade try each associated SimFlag in turn
//    until a query succeeds or the list of associated SimFlags is exhausted.


//  Program Notes:-
//  =============

//  None.


  SK_DBI_Trace( "Creating TDbiValidityRecBuilder" << "  ");

  DbiDetector::Detector_t     det(vc.GetDetector());
  DbiSimFlag::SimFlag_t       sim(vc.GetSimFlag());
  TVldTimeStamp             ts(vc.GetTimeStamp());
  DbiSimFlag::SimFlag_t       simTry(sim);
  const string& tableName = proxy.GetTableName();
  Int_t sumTimeWindows = 0;
  Int_t numTimeWindows = 0;

//  Contruct a default (gap) validity record fGap.
//  If findFullTimeWindow then gap will be unlimited but will be trimmed
//  after each query.

  this->MakeGapRec(vc, tableName, findFullTimeWindow);

//  Force aggregate -1 into first slot.
  this->AddNewGap(-1);

  const TVldTimeStamp curVTS = vc.GetTimeStamp();

// Check to see if table exists.

  unsigned int numVRecIn = 0;

  if ( ! proxy.TableExists() ) {
       SK_DBI_Warn(  "TDbiValidityRecBuilder::Query for table:"
         << proxy.GetTableName()
         << ", table does not exist!" << "  ");
  }

  else {

//  Loop over all databases in cascade until valid data found.

//  Determine the resolution scheme for resolving VLD overlaps.
    Bool_t resolveByCreationDate = ! proxy.HasEpoch();

    UInt_t numDb     = proxy.GetNumDb();
    Bool_t foundData = kFALSE;

    for ( UInt_t dbNo = 0; dbNo < numDb && ! foundData; ++dbNo ) {

      // Skip if cascade entry does not have this table or selection in force and not the required one.
      if ( ! proxy.TableExists(dbNo) ) continue;
      if ( selectDbNo >= 0 && selectDbNo != (int) dbNo ) continue;

//    Loop over all associated SimFlags.

      TDbiSimFlagAssociation::SimList_t simList
                    = TDbiSimFlagAssociation::Instance().Get(sim);

      TDbiSimFlagAssociation::SimList_t::iterator listItr    = simList.begin();
      TDbiSimFlagAssociation::SimList_t::iterator listItrEnd = simList.end();
      while ( listItr !=  listItrEnd && ! foundData ) {

        simTry = *listItr;
        ++listItr;
        TVldContext vcTry(det,simTry,ts);

//      Apply validity query and build result set.

        TDbiInRowStream* rs = proxy.QueryValidity(vcTry,fTask,dbNo);

//      Build a result from the result set and drop result set.

        TDbiValidityRec tr;
        TDbiResultSetNonAgg result(rs,&tr,0,kFALSE);
        delete rs;

//      Loop over all entries in TDbiResultSet and, for each Aggregate,
//      find effective validity range of best, or of gap if none.

//      Initialise lowest priority VLD to a gap. It will be used by FindTimeBoundaries.
        const TDbiValidityRec* lowestPriorityVrec = &fGap;

        UInt_t numRows = result.GetNumRows();
        for (UInt_t row = 0; row < numRows; ++row) {
          const TDbiValidityRec* vr = dynamic_cast<const TDbiValidityRec*>(
                                            result.GetTableRow(row));

          Int_t aggNo = vr->GetAggregateNo();

//        If starting a new aggregate prime it as a gap.
          Int_t index = this->IndexOfAggno(aggNo);
          if ( index < 0 ) index = this->AddNewGap(aggNo);

//        Trim the validity record for the current aggregate
//        number by this record and see if we have found valid
//        data yet.

          TDbiValidityRec& curRec = fVRecs[index];
          curRec.Trim(curVTS, *vr);
          if ( ! curRec.IsGap() ) {
            foundData = kTRUE;

//          Fill in entry's database number - its not stored in the
//          database table!
            curRec.SetDbNo(dbNo);
          }

//        Find the lowest priority non-gap VLD  that is used
          if (    lowestPriorityVrec->IsGap()
               || lowestPriorityVrec->IsHigherPriority(curRec,resolveByCreationDate)
                  )lowestPriorityVrec = &curRec;

//        Count the number used and sum the time windows
          ++numVRecIn;
          const TVldRange range = vr->GetVldRange();
          Int_t timeInterval =   range.GetTimeEnd().GetSec()
                               - range.GetTimeStart().GetSec();
          if ( timeInterval < 5 ) {
               SK_DBI_Warn(  "Detected suspiciously small validity time interval in \n"
            << "table " << tableName << " validity rec " << *vr << "  ");
          }
          sumTimeWindows += timeInterval;
          ++numTimeWindows;
        }

//      If finding findFullTimeWindow then find bounding limits
//      for the cascade and sim flag and trim all validity records
//      and the default (gap) validity record.
        if ( findFullTimeWindow ) {
          TVldTimeStamp start, end;
          proxy.FindTimeBoundaries(vcTry,fTask,dbNo,*lowestPriorityVrec,resolveByCreationDate,start,end);
     SK_DBI_Debug("Trimming validity records to "
    << start << " .. " << end << "  ");
          std::vector<TDbiValidityRec>::iterator itr(fVRecs.begin()), itrEnd(fVRecs.end());
          for( ; itr != itrEnd; ++itr ) itr->AndTimeWindow(start,end);
          fGap.AndTimeWindow(start,end);
        }
      }

    }
  }

//  If the query found no records in any database then
//  the tables will still have something - the aggno = -1 gap

// If the associated SimFlag is different to the original request make
// sure that all the TDbiValidityRec are valid for the request.
  if ( sim != simTry ) {
    SK_DBI_Log( "Imposing SimFlag of " << sim << " on TDbiValidityRecs which matched " << simTry << "  ");
    for ( unsigned int irec = 0; irec < GetNumValidityRec(); ++irec ) {
      TDbiValidityRec& vrec = const_cast<TDbiValidityRec&>(GetValidityRec(irec));
      const TVldRange& vr(vrec.GetVldRange());
      TVldRange vr_mod(vr.GetDetectorMask(),sim,vr.GetTimeStart(),vr.GetTimeEnd(),vr.GetDataSource());
      vrec.SetVldRange(vr_mod);
    }
  }

  // hand edit applied 
  
  SK_DBI_Verbose("TDbiValidityRecBuilder:" << endl
               << " Query: " << vc.AsString() << endl
               << " using associated SimFlag: " << DbiSimFlag::AsString(simTry)
               << " for " << DbiSimFlag::AsString(sim)
               << " found " << numVRecIn
               << " vrecs in database, for " << fVRecs.size()
               << " aggregates:-.");
  
  for ( unsigned int irec = 0; irec < GetNumValidityRec(); ++irec ) {
    const TDbiValidityRec& vrec = GetValidityRec(irec);
    if ( vrec.GetAggregateNo() != -2)   
      SK_DBI_Verbose(" " << irec << " " << GetValidityRec(irec));
  }



// Adjust the time gate if grossly wrong.
  if ( numTimeWindows > 0 ) {
    Int_t timeGateCalc = 3 * fVRecs.size() * sumTimeWindows/numTimeWindows;
    // Limit to 100 days and allow for overflow.
    if ( timeGateCalc > 100*24*60*60 || timeGateCalc < 0
       ) timeGateCalc = 100*24*60*60;
    Int_t timeGateCurr = TDbi::GetTimeGate(tableName);
    if (    timeGateCurr < timeGateCalc/10
         || timeGateCurr > timeGateCalc*10
            ) {
      TDbi::SetTimeGate(tableName,timeGateCalc);
      if ( timeGateCalc != TDbi::GetTimeGate(tableName) ) {
           SK_DBI_Warn(  "The ignored time gate setting was calculated with the following data:-"
          << "\n   Context: " << vc << " task " << task  << " findFullTimeWindow " << findFullTimeWindow
          << "\n   Number of vrecs " << numTimeWindows
          << " total time (secs) of all vrecs " << sumTimeWindows
          << " Number of aggregates " << fVRecs.size() << "  ");
      }
    }
  }

  return;

}

Here is the call graph for this function: