RecordSetupModule.cxx

Go to the documentation of this file.

// $Id: RecordSetupModule.cxx,v 1.5 2007/11/10 16:24:52 schubert Exp $
//
// RecordSetupModule.cxx
//
// A JobControl Module for Data Record Setup Housekeeping.
//
// Author:  G. Irwin 5/2003
// JobModule Registry parameters (with default values) are:
//
// "CandRecordName" - "PrimaryCandidateRecord"
// "CandRecordTitle" - "Created by RecordSetupModule"
// "ConfigRecordName" - "AlgConfigRecord"
// "ConfigRecordTitle" - "Created by AlgFactory"

#include <cassert>

#include "Algorithm/AlgConfig.h"
#include "Algorithm/AlgFactory.h"
#include "Algorithm/ConfigRecord.h"
#include "CandData/CandHeader.h"
#include "CandData/CandRecord.h"
#include "CandData/RecordSetupModule.h"
#include "JobControl/JobCModuleRegistry.h"
#include "JobControl/JobCommand.h"
#include "MessageService/MsgService.h"
#include "MinosObjectMap/MomNavigator.h"
#include "RawData/RawDaqSnarlHeader.h"
#include "RawData/RawRecord.h"
#include "Validity/VldContext.h"

ClassImp(RecordSetupModule)

//......................................................................
CVSID("$Id: RecordSetupModule.cxx,v 1.5 2007/11/10 16:24:52 schubert Exp $");
JOBMODULE(RecordSetupModule, "RecordSetupModule",
                           "Module for Data Record Setup Housekeeping");

//......................................................................
RecordSetupModule::RecordSetupModule()
{
  MSG("RecSetup", Msg::kVerbose) << "RecordSetupModule::Constructor\n";
}

//......................................................................
RecordSetupModule::~RecordSetupModule() 
{
  MSG("RecSetup", Msg::kVerbose) << "RecordSetupModule::Destructor\n";
}

//......................................................................
void RecordSetupModule::BeginJob() 
{
  MSG("RecSetup", Msg::kVerbose) << "RecordSetupModule::BeginJob\n";
}

//......................................................................
void RecordSetupModule::Config(const Registry& /* r */) 
{
  MSG("RecSetup", Msg::kDebug) << "RecordSetupModule::Config" << endl;
}

//......................................................................
const Registry& RecordSetupModule::DefaultConfig() const 
{
  MSG("RecSetup", Msg::kDebug)
    << "RecordSetupModule::DefaultConfig" << endl;

  static Registry r;
  
  std::string name = this->JobCModule::GetName();
  name += ".config.default";
  r.SetName(name.c_str());
  
  r.UnLockValues();
  r.Set("CandRecordName",    "PrimaryCandidateRecord");
  r.Set("CandRecordTitle",   "Created by RecordSetupModule");
  r.Set("ConfigRecordName",  "AlgConfigRecord");
  r.Set("ConfigRecordTitle", "Created by AlgFactory");
  r.LockValues();

  return r;
}

//......................................................................
JobCResult RecordSetupModule::Get(MomNavigator *mom)
{
  JobCResult result(JobCResult::kPassed);

  MSG("RecSetup", Msg::kDebug) << "RecordSetupModule::Get\n";

// Cache JobModule Registry values for Get method
  const char *tmps = 0;

  const char *candrecordname = 0;
  const char *candrecordtitle = 0;
  const char *configrecordname = 0;
  const char *configrecordtitle = 0;

  Registry &r = GetConfig();     // Get this JobModule's Registry object
  if (r.Get("CandRecordName",        tmps)) candrecordname       = tmps;
  if (r.Get("CandRecordTitle",       tmps)) candrecordtitle      = tmps;
  if (r.Get("ConfigRecordName",      tmps)) configrecordname     = tmps;
  if (r.Get("ConfigRecordTitle",     tmps)) configrecordtitle    = tmps;

// Create a VldContext
  RawRecord *rawrec = dynamic_cast<RawRecord *>
                                        (mom->GetFragment("RawRecord"));
  if (!rawrec) {
    MSG("RecSetup", Msg::kWarning) << "No RawRecord in MOM." << endl;
    result.SetWarning().SetFailed();
    return result;
  }

  VldContext vldc = rawrec->GetRawHeader()->GetVldContext();
  Int_t run   = -1;
  Int_t snarl = -1;

  const RawDaqSnarlHeader* snarlHdr = 
     dynamic_cast<const RawDaqSnarlHeader*>(rawrec->GetRawHeader());
  if (snarlHdr) {
     run   = snarlHdr->GetRun();
     snarl = snarlHdr->GetSnarl();
  } else {
     const RawDaqHeader* daqHdr = 
        dynamic_cast<const RawDaqHeader*>(rawrec->GetRawHeader());
     if (daqHdr) {
        MSG("RecSetup", Msg::kWarning)
           << "RawRecord only had a RawDaqHeader"
           << " - CandHeader will have bogus Snarl #'s"
           << endl;
        run = daqHdr->GetRun();
     } else {
        MSG("RecSetup", Msg::kWarning)
           << "RawRecord didn't have RawDaqSnarlHeader"
           << " - CandHeader will have bogus Run/Snarl #'s"
           << endl;
        MSG("RecSetup", Msg::kWarning)
                     << "  List of RawDataBlocks in RawRecord:" << endl;
        TIter rbi = rawrec->GetRawBlockIter();
        TObject *tobj;
        RawDataBlock *rb;
        while ( (tobj = rbi()) ) {
           rb = dynamic_cast<RawDataBlock *>(tobj); 
           if (!rb) continue;
           MSG("RecSetup", Msg::kWarning)
                << "     " << rb->ClassName() << " : " 
                << rb->GetName()
                << "  0x" << hex << rb->GetBlockId().GetEncoded() << dec
                << endl;
        }
     }
  }

// Check if there's a PrimaryCandidateRecord fragment in MOM.
  CandRecord *candrec = dynamic_cast<CandRecord *>
             (mom->GetFragment("CandRecord", candrecordname));
  if (candrec == 0) {
    MSG("RecSetup", Msg::kDebug)
    << "No " << candrecordname << " in MOM.  Create a new one." << endl;

// Create a CandHeader - No event splitting so don't supply event number
    CandHeader *head = new CandHeader(vldc, run, snarl);

// Produce a CandRecord.  Have it adopt the header
    candrec = new CandRecord(head);

// Give the CandRecord to MOM to hold as a "fragment"
    candrec->SetName(candrecordname);
    candrec->SetTitle(candrecordtitle);

    RecJobHistory& jobhist 
              = const_cast<RecJobHistory&>(candrec->GetJobHistory());
    jobhist.Append(rawrec->GetJobHistory());
    jobhist.CreateJobRecord(RecJobHistory::kCand);

    mom->AdoptFragment(candrec);
  }

  return result;
}

//......................................................................
JobCResult RecordSetupModule::Reco(MomNavigator *mom)
{
  JobCResult result(JobCResult::kPassed);

  MSG("RecSetup", Msg::kDebug) << "RecordSetupModule::Reco\n";

// Cache JobModule Registry values for Put method
  const char *tmps = 0;

  const char *candrecordname = 0;
  const char *candrecordtitle = 0;
  const char *configrecordname = 0;
  const char *configrecordtitle = 0;

  Registry &r = GetConfig();     // Get this JobModule's Registry object
  if (r.Get("CandRecordName",        tmps)) candrecordname       = tmps;
  if (r.Get("CandRecordTitle",       tmps)) candrecordtitle      = tmps;
  if (r.Get("ConfigRecordName",      tmps)) configrecordname     = tmps;
  if (r.Get("ConfigRecordTitle",     tmps)) configrecordtitle    = tmps;

  CandRecord* candrec =
              dynamic_cast<CandRecord*>(mom->GetFragment("CandRecord"));
  if (candrec != 0) {
    const VldContext* vc = candrec->GetVldContext();   
    AlgFactory &af = AlgFactory::GetInstance();
    ConfigRecord *conrec = af.GetOwnedConfigRecord(vc);
    if (conrec) {
      if (configrecordname) conrec->SetName(configrecordname);
      if (configrecordtitle) conrec->SetTitle(configrecordtitle);
      mom->AdoptFragment(conrec);

// Begin diagnostic printout
      TIter criter = mom->FragmentIter();
      TObject *tob;
      MSG("RecSetup", Msg::kDebug) << "Mom Fragment List:" << endl;
      while ((tob = criter())) {
        MSG("RecSetup", Msg::kDebug)
                     << "Fragment Class = " << tob->ClassName()
                     << " Fragment Name = " << tob->GetName()
                     << " Fragment Title = " << tob->GetTitle() << endl;
      }
      TIter algiter = conrec->GetConfigIter();
      MSG("RecSetup", Msg::kDebug) << "AlgConfig List:" << endl;
      while ((tob = algiter())) {
        MSG("RecSetup", Msg::kDebug)
                       << "Config Class = "  << tob->ClassName()
                       << " Config Name = "  << tob->GetName() << endl;
      }
// End diagnostic printout

    }
  }
  return result;
}

---