LIStreamHunter.cxx

Go to the documentation of this file.

//                                                                     
// Program name and version: LIStreamHunter.cxx 1.0         
//                                                                     
// Package: LISummary 
//
// Coded by Jeff Hartnell Nov/2002  
//
// Purpose: To find runs containing the LI stream
//                                                                    
// Contact: jeffrey.hartnell@physics.ox.ac.uk   

#include "TDatime.h"

#include "JobControl/JobCModuleRegistry.h"
#include "JobControl/JobCommand.h"
#include "MessageService/MsgService.h"
#include "MinosObjectMap/MomNavigator.h"
#include "RawData/RawLIAdcSummary.h"
#include "RawData/RawDaqHeader.h"
#include "RawData/RawDaqSnarlHeader.h"
#include "RawData/RawLIAdcSummaryBlock.h"
#include "RawData/RawRecord.h"
#include "RawData/RawLIHeader.h" 

#include "LISummary/LIStreamHunter.h"

#include <cassert>

ClassImp(LIStreamHunter)

JOBMODULE(LIStreamHunter,"LIStreamHunter","A module to find runs containing the LI stream");

CVSID("$Id: LIStreamHunter.cxx,v 1.1 2003/07/28 11:05:17 hartnell Exp $");

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

LIStreamHunter::LIStreamHunter()
{
  MSG("LIStreamHunter",Msg::kDebug) 
    << "Running LIStreamHunter Constructor..." << endl;

  runNumber=0;
  runNumberSub=0;
  runType=0;

  lastRunNumber=-1;
  lastRunNumberSub=-1;
  foundSummaries=0;

  timeSec=-1;
  timeNanoSec=-1;
  calibPoint=-1;
  pulserBox=-1;
  led=-1;
  pulseHeight=-1;
  pulseWidth=-1;
  
  lastLed=0;
  lastPulseHeight=0;
  lastPulseWidth=0;
  lastPulserBox=0;
  lastCalibPoint=0;

  numSummaries=0;
  numSummariesSub=0;

  MSG("LIStreamHunter",Msg::kDebug) 
    << "Finished LIStreamHunter Constructor" << endl;
};

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

LIStreamHunter::~LIStreamHunter(){

  MSG("LIStreamHunter",Msg::kDebug) 
    << "Running LIStreamHunter destructor..." << endl;


  MSG("LIStreamHunter",Msg::kDebug) 
    << "Finished LIStreamHunter destructor" << endl;
}

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

JobCResult LIStreamHunter::Ana(const MomNavigator *mom)
{
  JobCResult result(JobCResult::kPassed);

  //check that mom exists.
  assert(mom);
  
  //find raw record in mom
  RawRecord *rawrec = dynamic_cast<RawRecord *>
    (mom->GetFragment("RawRecord"));
  
  if (!rawrec) {
    MSG("LIStreamHunter",Msg::kInfo) 
      <<"No raw record found"<<endl;
    result.SetError().SetFailed();
    return result;
  }

  //get raw header
  const RawDaqHeader *RawHdr=
     dynamic_cast<const RawDaqHeader*>(rawrec->GetRawHeader());
  if (RawHdr){
    runNumber=RawHdr->GetRun();
    runNumberSub=RawHdr->GetSubRun();
    runType=RawHdr->GetRunType();
  }

  //print number of summaries in previous sub run
  if (runNumberSub!=lastRunNumberSub){
    if (foundSummaries==1 && numSummariesSub==0){
      MSG("LIStreamHunter",Msg::kInfo) 
        << " ** Empty LightInjection stream **" << endl;
    }
    else if (numSummariesSub>0){
      MSG("LIStreamHunter",Msg::kInfo) 
        << numSummariesSub << " summaries found" << endl << endl;
    }  
    numSummariesSub=0;
    foundSummaries=0;
  }

  if (runNumber>lastRunNumber){
    MSG("LIStreamHunter",Msg::kInfo) 
      << "***************************" << endl
      << "** New Run Number: " << runNumber << " **" << endl 
      << "***************************" << endl; 
    lastRunNumberSub=-1;//might only have one sub run so reset here
  }
  lastRunNumber=runNumber;
  if (runNumberSub!=lastRunNumberSub){
    MSG("LIStreamHunter",Msg::kInfo) 
      << "Analysing Sub Run " << runNumberSub << " ..." << endl; 
  }
  lastRunNumberSub=runNumberSub;

  //get LI Summary block from rawdatablock
  const RawLIAdcSummaryBlock *rawliadcsummaryblock=0;
  rawliadcsummaryblock=dynamic_cast<const RawLIAdcSummaryBlock*>
  (rawrec->FindRawBlock("RawLIAdcSummaryBlock"));

//   const RawDaqSnarlHeader *rawdaqsnarlheader= 
//     dynamic_cast<const RawDaqSnarlHeader*>
//     (rawrec->FindRawBlock("RawDaqSnarlHeader"));

//   if(!rawdaqsnarlheader){  
//     //result.SetError().SetFailed();
//     //return result;
//     MSG("LIStreamHunter",Msg::kInfo) 
//       << "not rawdaqsnarlheader=" << rawdaqsnarlheader << endl;
//   }
//   else{
//     MSG("LIStreamHunter",Msg::kInfo) 
//       << "Found rawdaqsnarlheader=" << rawdaqsnarlheader << endl
//       << "TrigSrc=" << rawdaqsnarlheader->GetTrigSrc() << endl
//       << "ErrorCode=" << rawdaqsnarlheader->GetErrorCode() << endl
//       << "NumRawDigits=" << rawdaqsnarlheader->GetNumRawDigits()<< endl;
//   }
  
  if(!rawliadcsummaryblock){ 
    MSG("LIStreamHunter",Msg::kInfo) 
      <<"No rawliadcsummaryblock found"<<endl;
    result.SetError().SetFailed();
    return result;
  }

  timeStamp=rawliadcsummaryblock->GetTimeStamp();
  timeSec=timeStamp.GetSec();
  timeNanoSec=timeStamp.GetNanoSec();
  calibPoint=rawliadcsummaryblock->GetCalibPoint();
  pulserBox=rawliadcsummaryblock->GetPulserBox();
  led=rawliadcsummaryblock->GetLed();
  pulseHeight=rawliadcsummaryblock->GetPulseHeight();
  pulseWidth=rawliadcsummaryblock->GetPulseWidth();
  
  if(led!=lastLed || pulseHeight!=lastPulseHeight ||
     pulseWidth!=lastPulseWidth || pulserBox!=lastPulserBox ||
     calibPoint!=lastCalibPoint){
    
    TDatime datime;
    datime.Set(timeSec);
    MSG("LIStreamHunter",Msg::kVerbose)  
      << "PB=" << pulserBox 
      << " Led=" << led
      << " calpt=" << calibPoint
      << " Hgt=" << pulseHeight
      << " Wth=" << pulseWidth
      << " at " << datime.GetTime() 
      << " on " << datime.GetDate() << endl;   
  }
  lastLed=led;
  lastPulseHeight=pulseHeight;
  lastPulseWidth=pulseWidth;
  lastPulserBox=pulserBox;
  lastCalibPoint=calibPoint;

  //count number of summaries
  numSummariesSub+=rawliadcsummaryblock->GetNumberOfSummaries();
  //set control flag
  foundSummaries=1;
  
  return result;
}

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

void LIStreamHunter::EndJob() 
{
  if (foundSummaries==0){
    MSG("LIStreamHunter",Msg::kInfo) 
      <<endl
      << " ** No LightInjection stream found **" 
      <<endl
      <<endl;
  }
  else if (foundSummaries==1 && numSummariesSub==0){
    MSG("LIStreamHunter",Msg::kInfo) 
      << " ** Empty LightInjection stream **" << endl;
  }
  else if (numSummariesSub>0){
    MSG("LIStreamHunter",Msg::kInfo) 
      << numSummariesSub << " summaries found" << endl << endl;
  }
  return;
}

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

---