NtpStModule.cxx

Go to the documentation of this file.

//
// NtpStModule.cxx
//
// A JobControl Module for creating an NtpStRecord
//
#include <iostream>
using namespace std;

#include "StandardNtuple/NtpStRecord.h"
#include "StandardNtuple/Module/NtpStModule.h"
#include "MessageService/MsgService.h"
#include "JobControl/JobCModuleRegistry.h"
#include "JobControl/JobCommand.h"
#include "MinosObjectMap/MomNavigator.h"
#include "Record/RecCandHeader.h"
#include "Record/SimSnarlRecord.h"
#include "Record/SimSnarlHeader.h"
#include "CandData/CandRecord.h"
#include "CandData/CandHeader.h"
#include "RawData/RawRecord.h"
#include "RawData/RawDaqSnarlHeader.h"
#include <cassert>

ClassImp(NtpStModule)

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

CVSID("$Id: NtpStModule.cxx,v 1.6 2007/11/10 16:42:44 schubert Exp $");
JOBMODULE(NtpStModule, "NtpStModule",
         "A module for filling Standard ntuple records.");


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


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

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

  MSG("NtpSt",Msg::kDebug) << "NtpStModule::DefaultConfig" << endl;

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

  r.UnLockValues();
  // insert configuration default definitions here
  r.Set("RecordName","Primary");
  r.Set("RecordTitle","Created by NtpStModule");
  r.Set("CandRecordName","PrimaryCandidateRecord");
  
  r.LockValues();

  return r;
}

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

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

  MSG("NtpSt",Msg::kDebug) << "NtpStModule::Config" << endl;
  
  //Int_t tmpi;
  //Double_t tmpd;
  const Char_t* tmps;
  if ( r.Get("RecordName", tmps) )  fRecordName = tmps;
  if ( r.Get("RecordTitle", tmps) ) fRecordTitle = tmps;
  if ( r.Get("CandRecordName",tmps) ) fCandRecordName = tmps;

}

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

JobCResult NtpStModule::Get(MomNavigator *mom) {
  //
  //  Purpose:  Create standard ntuple record.
  //
  //  Arguments: mom.
  //  
  //  Return: status.
  // 

  JobCResult result(JobCResult::kPassed);  
  MSG("NtpSt",Msg::kDebug) << "NtpStModule::Get" << endl;

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

  const CandRecord* cndrec = dynamic_cast<const CandRecord*>
          (mom->GetFragment("CandRecord",fCandRecordName.c_str()));
  const SimSnarlRecord* simrec = dynamic_cast<const SimSnarlRecord*>
          (mom->GetFragment("SimSnarlRecord"));
  if (!cndrec && !simrec ) {
    MSG("NtpSt",Msg::kWarning) 
    << "No PrimaryCandidateRecord or SimSnarlRecord in Mom" << endl;
    result.SetWarning().SetFailed();
    return result;
  }

  NtpStRecord* ntprec = 0;
  if ( !cndrec ) {
    // Use SimSnarlRecord header
    const SimSnarlHeader* simhdr = simrec->GetSimSnarlHeader();

    RecCandHeader ntphdr(simhdr->GetVldContext(),simhdr->GetRun(),
         simhdr->GetSubRun(),simhdr->GetRunType(),simhdr->GetErrorCode(),
         simhdr->GetSnarl(),simhdr->GetTrigSrc(),simhdr->GetTimeFrame(),
         simhdr->GetRemoteSpillType(),-1);
    ntprec = new NtpStRecord(ntphdr);
    ntprec -> SetName(fRecordName.c_str());
    ntprec -> SetTitle(fRecordTitle.c_str());

    RecJobHistory& jobhist
      = const_cast<RecJobHistory&>(ntprec->GetJobHistory());
    jobhist.Append(simrec->GetJobHistory());
    jobhist.CreateJobRecord(RecJobHistory::kNtpSt);

    mom -> AdoptFragment(ntprec); // pass record to mom to own
    return result; // a triggerless event
  }
  

  // Extract header from CandRecord and use this to create RecCandHeader
  // and NtpStRecord.
  const CandHeader* cndhdr = cndrec -> GetCandHeader();
  const RawRecord* rawrec = 
   dynamic_cast<const RawRecord*>(mom->GetFragment("RawRecord","","DaqSnarl"));
  if (!rawrec) {
    MSG("NtpSt",Msg::kWarning) << "No DaqSnarl RawRecord in Mom"
       <<"\nShield data will not be filled and header will be incomplete." 
       << endl;
    result.SetWarning();
  }
  if (rawrec) {  
    const RawDaqSnarlHeader* rawhdr = dynamic_cast<const RawDaqSnarlHeader*>
                                      (rawrec -> GetRawHeader());
    RecCandHeader ntphdr(rawhdr->GetVldContext(),rawhdr->GetRun(),
         rawhdr->GetSubRun(),rawhdr->GetRunType(),rawhdr->GetErrorCode(),
         rawhdr->GetSnarl(),rawhdr->GetTrigSrc(),rawhdr->GetTimeFrameNum(),
         rawhdr->GetRemoteSpillType(),cndhdr->GetEvent());
    ntprec = new NtpStRecord(ntphdr);
  }
  else {
    // This dependency is terrible, but is because CandRecord never made
    // the transition to new base class and CandHeader is incomplete
    RecCandHeader ntphdr(cndhdr->GetVldContext(),cndhdr->GetRun(),
           -1,-1,0,cndhdr->GetSnarl(),0,-1,-1,cndhdr->GetEvent());
    ntprec = new NtpStRecord(ntphdr);
  }
  
  ntprec -> SetName(fRecordName.c_str());
  ntprec -> SetTitle(fRecordTitle.c_str());

  RecJobHistory& jobhist
      = const_cast<RecJobHistory&>(ntprec->GetJobHistory());
  if ( simrec ) jobhist.Append(simrec->GetJobHistory());
  jobhist.Append(cndrec->GetJobHistory());
  jobhist.CreateJobRecord(RecJobHistory::kNtpSt);

  mom -> AdoptFragment(ntprec);  // pass record to mom to own

  return result;

}

---