FilterStream.cxx

Go to the documentation of this file.

// $Id: FilterStream.cxx,v 1.4 2005/02/22 21:41:07 bspeak Exp $
//
// FilterStream is a simple JobCModules that passes or failes events
// based on StreamType as configured in the Config method.
// If any of the four conditions are met, kPassed is returned
//
// Author: B. Speakman 2004.09.03
//
#include "CandData/CandRecord.h"
#include "JobControl/JobCModuleRegistry.h"
#include "MinosObjectMap/MomNavigator.h"
#include "MessageService/MsgService.h"
#include "RawData/RawRecord.h"

#include "FilterStream.h"
#include "RSM.h"

ClassImp(FilterStream)
CVSID("$Id: FilterStream.cxx,v 1.4 2005/02/22 21:41:07 bspeak Exp $");

JOBMODULE(FilterStream,"FilterStream","Filter on the Input Stream");

FilterStream::FilterStream() {
  RSMSyn << "FilterStream::FilterStream" << endl;
  fPassMonitor = true;
  fPassSnarl = true;
  fPassCand = true;
  fPassLI = true;
}

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

JobCResult FilterStream::Ana(const MomNavigator* mom) {
  RSMVer << "FilterStream::Ana" << endl;
  bool HasMonitor = false;
  bool HasSnarl = false;
  bool HasCand = false;
  bool HasLI = false;

  const char* rcInStr = 0;
  RawRecord* record = 0;
  CandRecord* candrec = 0;

  TIter itr = const_cast<MomNavigator*>(mom)->FragmentIter();

  TObject *obj = 0;
  while ((obj=itr())) {
    if ((record=dynamic_cast<RawRecord*>(obj))) {
      if(!record->GetTempTags().Get("stream",rcInStr)) continue;

      if(!strcmp("DaqMonitor",rcInStr)) HasMonitor = true;
      if(!strcmp("DaqSnarl",rcInStr)) HasSnarl = true;
      if(!strcmp("LightInjection",rcInStr)) HasLI = true;
    }
    if((candrec=dynamic_cast<CandRecord*>(obj))) HasCand = true;
  }

  if(HasMonitor && fPassMonitor) return JobCResult::kPassed;
  if(HasSnarl && fPassSnarl) return JobCResult::kPassed;
  if(HasLI && fPassLI) return JobCResult::kPassed;
  if(HasCand && fPassCand) return JobCResult::kPassed;

  return JobCResult::kFailed;
}

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

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

  r.UnLockValues();

  r.Set("PassMonitor",1);
  r.Set("PassSnarl",1);
  r.Set("PassCand",1);
  r.Set("PassLI",1);

  r.LockValues();

  return r;
}

void FilterStream::Config(const Registry& r) {
  RSMSyn << "FilterStream::Config" << endl;
  int tmpi=0;
  if(r.Get("PassMonitor",tmpi)) fPassMonitor = static_cast<bool>(tmpi);
  if(r.Get("PassSnarl",tmpi)) fPassSnarl = static_cast<bool>(tmpi);
  if(r.Get("PassCand",tmpi)) fPassCand = static_cast<bool>(tmpi);
  if(r.Get("PassLI",tmpi)) fPassLI = static_cast<bool>(tmpi);
}

---