PulserTimingMaker.cxx

Go to the documentation of this file.

// $Id: PulserTimingMaker.cxx,v 1.6 2007/03/01 17:06:40 rhatcher Exp $
//
// FILL_IN: [Document your code!!]
//
// n.tagg1@physics.ox.ac.uk
#include "PulserTimingMaker.h"
#include "PulserTimingPoint.h"
#include "RawData/RawRecord.h"
#include "RawData/RawHeader.h"
#include "RawData/RawLITimingSummary.h"
#include "RawData/RawLITimingSummaryBlock.h"
#include "MessageService/MsgService.h"
#include "MinosObjectMap/MomNavigator.h"
#include "JobControl/JobCModuleRegistry.h" // For JOBMODULE macro
#include "DataUtil/DumpMom.h"
#include "TFile.h"


JOBMODULE(PulserTimingMaker, "PulserTimingMaker",
          "Makes pulser timing points from LI summaries");
CVSID("$Id: PulserTimingMaker.cxx,v 1.6 2007/03/01 17:06:40 rhatcher Exp $");
//......................................................................

PulserTimingMaker::PulserTimingMaker()
{
  fCurrentPoint = 0;
  TFile savefile("PulserTimingPoint.open.root","READ");
  if(!(savefile.IsZombie())) {
    fCurrentPoint = dynamic_cast<PulserTimingPoint*> (savefile.Get("PulserTimingPoint"));
    if(fCurrentPoint) MSG("PulserTiming",Msg::kInfo) << "Loaded saved point: " << fCurrentPoint->AsString() << endl;
  }

  if(fCurrentPoint==0) 
    MSG("PulserTiming",Msg::kInfo) << "Failed to load saved point" << endl;
}

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

PulserTimingMaker::~PulserTimingMaker()
{
  //FinishPoint();
}

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

JobCResult PulserTimingMaker::Ana(const MomNavigator* mom)
{

  // Find the RawRecord, if any.

  //DataUtil::dump_mom(mom,std::cout);

  JobCResult result = JobCResult::kFailed;

  Bool_t anyData = false;
  VldContext now;

  TObject* tobj;
  const RawRecord* rawrec = 0;
  // Find the raw record. Assumes only 1.
  TIter    fragiter = mom->FragmentIter();
  while( ( tobj = fragiter.Next() ) ) {
    rawrec = dynamic_cast<const RawRecord*>(tobj);
    if(rawrec) {

      anyData = true;
      now = (rawrec->GetRawHeader())->GetVldContext();
      
      // Ask the RawRecord for an iterator over its RawDatBlocks
      TIter itr = rawrec->GetRawBlockIter();
      RawDataBlock* rawBlk;
      while ( ( rawBlk = dynamic_cast<RawDataBlock*>(itr.Next()) ) ) {
        
        // Find the timing summary block, if any.
        const RawLITimingSummaryBlock *sumblock =
          dynamic_cast<const RawLITimingSummaryBlock *>(rawBlk);
        
        if(sumblock) {

          result = JobCResult::kPassed;
 
          // Ok, we have a summary block.
          // Do we already have a point running?
          
          if(fCurrentPoint) {
            // See if the new block fits in with the current one.
            if(fCurrentPoint->AddSummaryBlock(sumblock)) {
              // All is well. We added it sucessfully.
              MSG("PulserTiming",Msg::kInfo) << "Summary block added successfully to " 
                                             << fCurrentPoint->AsString() << endl;
            } else {
              // The old point must be done. Finish it off.
              FinishPoint();
              // And start a new one.
              fCurrentPoint = new PulserTimingPoint(sumblock);
              MSG("PulserTiming",Msg::kInfo) << "Started new point:                  "
                                             << fCurrentPoint->AsString() << endl;
            }
          } else {
            // Don't have a point going yet; add it.
        fCurrentPoint = new PulserTimingPoint(sumblock);
        MSG("PulserTiming",Msg::kInfo) << "Started new point:                    "
                                       << fCurrentPoint->AsString() << endl;
          }
          
        } // if(sumblock)
        
      }
    }
  }
   
  if(anyData) { // There was at least a VldTimeStamp on this Mom.

    if(fCurrentPoint) {
      if(fCurrentPoint->PointTimedOut(now.GetTimeStamp(),fSummaryTimeout)) {
        MSG("PulserTiming",Msg::kInfo) << "Point timed out. " << now.AsString() << "  " << fSummaryTimeout << endl;
        FinishPoint();
      } else if( fCurrentPoint->PointIsFinished() ) {
        MSG("PulserTiming",Msg::kInfo) << "Point finished.  ";
        FinishPoint();
      }
    }
    
    // Save progress.
    if(fCurrentPoint) {
      TFile savefile("PulserTimingPoint.open.root","RECREATE");
      fCurrentPoint->Write("PulserTimingPoint",TObject::kOverwrite);
      savefile.Close();
    }
    
  }
  return result; // kNoDecision, kFailed, etc.
}


//......................................................................
void PulserTimingMaker::FinishPoint()
{
  if(fCurrentPoint) {
    MSG("PulserTiming",Msg::kInfo) << "Current timing point finishing." << endl;
    if(fCurrentPoint->PointIsGood()) 
      if(fWriteDatabase) {
        MSG("PulserTiming",Msg::kInfo) << "Writing point to DB..." << endl;
        fCurrentPoint->WriteToDatabase();
      }
    if(fWriteTextfile) {
      MSG("PulserTiming",Msg::kInfo) << "Writing point to text file..." << endl;
      fCurrentPoint->WriteToTextfile("endrun");      
    }
    
    delete fCurrentPoint;
    fCurrentPoint = 0;
  }
}

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

const Registry& PulserTimingMaker::DefaultConfig() const
{
//======================================================================
// Supply the default configuration for the module
//======================================================================
  static Registry r; // Default configuration for module

  // Set name of config
  std::string name = this->GetName();
  name += ".config.default";
  r.SetName(name.c_str());

  // Set values in configuration
  r.UnLockValues();
  r.Set("writeDatabase",  1);
  r.Set("writeTextfile",  0);
  r.Set("summaryTimeout", 600.0);
  r.LockValues();

  return r;
}

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

void PulserTimingMaker::Config(const Registry& r)
{
//======================================================================
// Configure the module given the Registry r
//======================================================================
  int    tmpi;
  double tmpd;

  if (r.Get("writeDatabase",tmpi)) { fWriteDatabase = tmpi; }
  if (r.Get("writeTextfile",tmpi)) { fWriteTextfile = tmpi; }
  if (r.Get("summaryTimeout",tmpd)) { fSummaryTimeout = tmpd; }
}

---