NtpSRFilterModule.cxx

Go to the documentation of this file.

//
// NtpSRFilterModule.cxx
//
// A JobControl Module for filtering a filled NtpSRRecord to a subset
// of its data.
//
#include <iostream>
using namespace std;

#include "CandNtupleSR/Module/NtpSRFilterModule.h"
#include "CandNtupleSR/NtpSRRecord.h"
#include "MessageService/MsgService.h"
#include "JobControl/JobCModuleRegistry.h"
#include "JobControl/JobCommand.h"
#include "MinosObjectMap/MomNavigator.h"

#include <cassert>

ClassImp(NtpSRFilterModule)

//   Definition of static data members
//   *********************************

CVSID("$Id: NtpSRFilterModule.cxx,v 1.10 2005/03/06 04:26:34 asousa Exp $");
JOBMODULE(NtpSRFilterModule, "NtpSRFilterModule",
         "A module for filtering filled SR ntuple records.");


// Definition of methods (alphabetical order)
// ***************************************************

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

const Registry& NtpSRFilterModule::DefaultConfig() const {
  //
  // Purpose: Method to return default configuration.
  // 
  // Arguments: none.
  //
  // Return: Registry containing default configuration
  //

  MSG("NtpSR",Msg::kDebug) << 
    "NtpSRFilterModule::DefaultConfig" << endl;

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

  r.UnLockValues();
  r.Set("PreScale",1000000000);
  r.Set("RecordName","Primary");
  r.LockValues();

  return r;
}

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

void NtpSRFilterModule::Config(const Registry& r) {
  //
  // Purpose: Configure the module given a registry.
  //
  // Arguments: Registry to use to configure the module.
  //
  // Return: none.
  //

  MSG("NtpSR",Msg::kDebug) << "NtpSRFilterModule::Config" << endl;
  
  Int_t tmpi;
  //  Double_t tmpd;
  const Char_t* tmps;

  if ( r.Get("PreScale",tmpi) ) fPreScale = tmpi;
  if ( r.Get("RecordName",tmps) ) fRecordName = tmps;

}

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

JobCResult NtpSRFilterModule::Reco(MomNavigator *mom) {
  //
  //  Purpose:  Filter contents of existing ntuple record.
  //
  //  Arguments: mom.
  //  
  //  Return: status.
  // 

  JobCResult result(JobCResult::kPassed);  
  MSG("NtpSR",Msg::kDebug) << "NtpSRFilterModule::Reco" << endl;

  // Check that mom exists.
  assert(mom);

  NtpSRRecord* ntprec = dynamic_cast<NtpSRRecord*>
     (mom->GetFragment("NtpSRRecord",fRecordName.c_str()));
  if (!ntprec) {
    MSG("NtpSR",Msg::kWarning) << "No NtpSRRecord of name " 
                               << fRecordName.c_str() << " in Mom" << endl;
    result.SetWarning().SetFailed();
    return result;
  }

  fNReco++;
  if ( fNReco%fPreScale == 0 ) return result; // every nth record is skipped

  // Purge strip data from record
  ntprec -> ClearStrips();

  return result;

}

---