FilterRunType.cxx

Go to the documentation of this file.

// $Id: FilterRunType.cxx,v 1.8 2007/11/14 14:08:52 bspeak Exp $
//
// FilterRunType is a simple JobCModules that passes or fails based on
// runtype pulled from either RawRecord, or RawRunConfigBlock if desired
//
// Author: B. Speakman 2004.09.03
//
#include "MinosObjectMap/MomNavigator.h"
#include "JobControl/JobCModuleRegistry.h"
#include "JobControl/JobCResult.h"
#include "MessageService/MsgService.h"
#include "RawData/RawSnarlHeaderBlock.h"
#include "RawData/RawDaqHeader.h"
#include "RawData/RawRecord.h"
#include "Validity/VldContext.h"
#include "RawData/RawRunConfigBlock.h"
#include "RawData/RawSpillServerMonitorBlock.h"
#include "OnlineUtil/mdRunTypeCodes.h"
#include "OnlineUtil/mdSpillData.h"

#include "FilterRunType.h"
#include "RSM.h"
#include "UtilRSM.h"

ClassImp(FilterRunType)
CVSID("$Id: FilterRunType.cxx,v 1.8 2007/11/14 14:08:52 bspeak Exp $");

JOBMODULE(FilterRunType,"FilterRunType","Filter on RunType");

FilterRunType::FilterRunType()
{
  RSMSyn << "FilterRunType::FilterRunType" << endl;
  fRun = 0;
  fSubRun = 0;

  fPassRun.SetPassed().SetAOK();
}

FilterRunType::~FilterRunType()
{
  RSMSyn << "FilterRunType::~FilterRunType" << endl;
}

JobCResult FilterRunType::Ana(const MomNavigator* mom)
{
  //RSMVer << "FilterRunType::Ana" << endl;

  RawRecord* rawrec = 0;
  const char* InputStream = 0;

  TIter momitr = const_cast<MomNavigator*>(mom)->FragmentIter();
  TObject* momobj = 0;
  while ((momobj=momitr())) {
    if ((rawrec=dynamic_cast<RawRecord*>(momobj))) {
      const RawSnarlHeaderBlock* hdrblk =
        dynamic_cast<const RawSnarlHeaderBlock*>
        (rawrec->FindRawBlock("RawSnarlHeaderBlock"));

      bool IsFakeSpill = false;
      if(hdrblk) {
        if(hdrblk->GetRemoteSpillType() == kSpillType_Fake) IsFakeSpill = true;
      }
      if(!IsFakeSpill && fOnlyFakeSpill) return JobCResult::kFailed;

      const RawDaqHeader* dhdr =
        dynamic_cast<const RawDaqHeader*>(rawrec->GetRawHeader());
  
      if (fRun!=dhdr->GetRun() || fSubRun!=dhdr->GetSubRun()) {
        if (fRun==dhdr->GetRun() && fPassRunTypeName.size()!=0) {
          //Don't change for just subrun changes when using RunTypeName
          RSMDeb << "Only SubRun Changed" <<endl;
          fSubRun = dhdr->GetSubRun();
          return fPassRun;
        }
        RSMDeb << "Run change: " <<
          fRun << "-" << fSubRun << " -> " <<
          dhdr->GetRun() << "-" << dhdr->GetSubRun() << endl;
  
        fRun = dhdr->GetRun();
        fSubRun = dhdr->GetSubRun();
        if(dhdr->GetVldContext().GetDetector()==Detector::kFar
           && fRun<=RUNNUM_NEW_RUNTYPES) {
          RSMDeb << "I can't play with early far runtypes yet" <<endl;
          fPassRun.SetPassed();
          return fPassRun;
        }
        fPassRun.SetPassed();
        RSMDeb << "fPassRun:" << fPassRun << endl;
      }
      else {
        //RSMVer << "No Run change, fPassRun:" << fPassRun << endl;
        return fPassRun;
      }
      Short_t RType = dhdr->GetRunType();
      Short_t BaseRType = RType&RUN_TYPE_MASK_TYPECODE;
      if (fPassRunType != 0) {
        if(fPassRunType!=RType || fPassRunType!=BaseRType) {
          fPassRun.SetFailed();
        }
        RSMDeb << "fPassRun:" << fPassRun << endl;
      }
      else {
        if((RType&RUN_TYPE_MASK_TEST)!=0
           && !fPassTest) fPassRun.SetFailed();
        if((RType&RUN_TYPE_MASK_MODIFIED)!=0
           && !fPassModified) fPassRun.SetFailed();
        if(BaseRType==RUN_TYPE_PHYSICS
           && !fPassPhysics) fPassRun.SetFailed();
        if(BaseRType==RUN_TYPE_CHECKOUT
           && !fPassCheckOut) fPassRun.SetFailed();
        if(BaseRType==RUN_TYPE_VA_CALIBRATE
           && !fPassVACalibrate) fPassRun.SetFailed();
        if(BaseRType==RUN_TYPE_VA_PEDESTAL
           && !fPassVAPedestal) fPassRun.SetFailed();
        if(BaseRType==RUN_TYPE_QIE_CALIBRATE
           && !fPassQieCalibrate) fPassRun.SetFailed();
        if(BaseRType==RUN_TYPE_QIE_MONITOR
           && !fPassQieMonitor) fPassRun.SetFailed();
      }

      if (rawrec->GetTempTags().Get("stream",InputStream)
           && fPassRunTypeName.size()!=0) {
        fPassRun.SetFailed();
        if (!strcmp("DaqMonitor",InputStream)) {
          TIter rawitr = rawrec->GetRawBlockIter();
          RawRunConfigBlock* rrcfgb = 0;
          TObject *rawobj = 0;
          while ((rawobj=rawitr())) {
            if ( (rrcfgb = dynamic_cast<RawRunConfigBlock*>(rawobj)) ) {
              RSMDeb << "RawRunConfigBlock for: " <<
                rrcfgb->GetRun() << "-" << rrcfgb->GetSubRun() << 
                endl << "[" << rrcfgb->GetRunConfig() << "]" << endl;
              string rtname;
              rtname = UtilRSM::ParseConfigBlock(rrcfgb,"runTypeName");
              if(fPassRunTypeName == rtname) fPassRun.SetPassed();
              RSMDeb << "fPassRun:" << fPassRun << endl;
            }
          }
        }
      }
    }
  }
  return fPassRun;
}

void FilterRunType::BeginJob()
{
  RSMSyn << "FilterRunType::BeginJob" << endl;
  fRun = 0;
  fSubRun = 0;
}

void FilterRunType::EndJob()
{
  RSMSyn << "FilterRunType::EndJob" << endl;
}

const Registry& FilterRunType::DefaultConfig() const
{
  RSMSyn << "FilterRunType::DefaultConfig" << endl;
  static Registry r;

  string name = this->JobCModule::GetName();
  r.SetName((name+".config.default").c_str());

  r.UnLockValues();

  //These are for specific RunTypes, pass all by default
  r.Set("PassPhysics",1);
  r.Set("PassCheckOut",1);
  r.Set("PassVACalibrate",1);
  r.Set("PassVAPedestal",1);
  r.Set("PassQieCalibrate",1);
  r.Set("PassQieMonitor",1);
  r.Set("OnlyFakeSpill",0);

  //These are for status bits to RunType code
  r.Set("PassTest",1);
  r.Set("PassModified",1);

  //Use these to specify a RunType or RunType name to pass
  //If one of these are set, the above Pass value will be ignored and
  //only RunType == PassRunType or RunTypeName == PassRunTypeName will
  //go through
  r.Set("PassRunType",0);//0 to pass all RunType
  r.Set("PassRunTypeName","");// Empty string to pass all RunTypeName

  r.LockValues();
  return r;
}

void FilterRunType::Config(const Registry& r)
{
  RSMSyn << "FilterRunType::Config" << endl;
  int tmpi = 0;
  const char* tmps = 0;

  if(r.Get("PassPhysics",tmpi)) fPassPhysics=tmpi;
  if(r.Get("PassCheckOut",tmpi)) fPassCheckOut=tmpi;
  if(r.Get("PassVACalibrate",tmpi)) fPassVACalibrate=tmpi;
  if(r.Get("PassVAPedestal",tmpi)) fPassVAPedestal=tmpi;
  if(r.Get("PassQieCalibrate",tmpi)) fPassQieCalibrate=tmpi;
  if(r.Get("PassQieMonitor",tmpi)) fPassQieMonitor=tmpi;
  if(r.Get("OnlyFakeSpill",tmpi)) fOnlyFakeSpill=tmpi;
  if(r.Get("PassTest",tmpi)) fPassTest=tmpi;
  if(r.Get("PassModified",tmpi)) fPassModified=tmpi;
  if(r.Get("PassRunType",tmpi)) fPassRunType=tmpi;
  if(r.Get("PassRunTypeName",tmps)) fPassRunTypeName=tmps;
}

---