DemoRecordModule.cxx

Go to the documentation of this file.

//
// DemoRecordModule.cxx
//
// A JobControl Module for demonstrating record construction.
//
#include <map>
#include <iostream>
using std::endl;
#include "TNamed.h"
#include "Record/test/DemoRecordModule.h"
#include "MessageService/MsgService.h"
#include "JobControl/JobCModuleRegistry.h"
#include "JobControl/JobCommand.h"
#include "MinosObjectMap/MomNavigator.h"
#include "RawData/RawRecord.h"
#include "RawData/RawHeader.h"
#include "RawData/RawDaqSnarlHeader.h"
#include "Record/RecPhysicsHeader.h"
#include "Record/RecDataRecord.h"

#include <cassert>

ClassImp(DemoRecordModule)

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

CVSID("$Id: DemoRecordModule.cxx,v 1.4 2005/05/18 03:02:57 schubert Exp $");
JOBMODULE(DemoRecordModule, "DemoRecordModule",
         "A module for demonstrating record construction.");


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

JobCResult DemoRecordModule::Ana(const MomNavigator *mom) {

  JobCResult result(JobCResult::kPassed);  
  MSG("DemoRecord",Msg::kVerbose) << "DemoRecordModule::Ana" << endl;

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

  // Retrieve record
  RecDataRecord<RecPhysicsHeader> *record 
  = dynamic_cast<RecDataRecord<RecPhysicsHeader>*>
    (mom->GetFragment("RecDataRecord<RecPhysicsHeader>"));
  if ( !record ) {
    MSG("DemoRecord",Msg::kWarning) << "No RecDataRecord in Mom " <<endl;
    result.SetWarning().SetFailed();
    return result;
  }
  MSG("DemoRecord",Msg::kInfo) 
    << "DemoRecordModule::Ana retrieved selected record:\n" << *record << endl;
  return result;
  
}

JobCResult DemoRecordModule::Reco(MomNavigator *mom) {
  //
  //  Purpose:  Create record.
  //
  //  Arguments: none.
  //  
  //  Return: none.
  //
  //  Contact:   S. Kasahara
  // 


  JobCResult result(JobCResult::kPassed);  
  MSG("DemoRecord",Msg::kVerbose) << "DemoRecordModule::Reco" << endl;

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

  // Create a RecDataRecord<RecPhysicsHeader> from a RawRecord (DaqSnarl) 
  // Should iterate, but this is just a demo
  RawRecord *rawRec = dynamic_cast<RawRecord*>(mom->GetFragment("RawRecord"));
  if ( !rawRec ) {
    MSG("RawRecord",Msg::kWarning) << "No RawRecord in Mom " <<endl;
    result.SetWarning().SetFailed();
    return result;
  }

  const RawDaqSnarlHeader* rawHdr = dynamic_cast<const RawDaqSnarlHeader*>
                              (rawRec -> GetHeader());
  RecPhysicsHeader* newHdr = new RecPhysicsHeader(rawHdr->GetVldContext(),
        rawHdr->GetRun(),rawHdr->GetSubRun(),rawHdr->GetRunType(),
        rawHdr->GetErrorCode(),rawHdr->GetSnarl(),rawHdr->GetTrigSrc(),
        rawHdr->GetTimeFrameNum(),rawHdr->GetRemoteSpillType());

  // Create new record
  RecDataRecord<RecPhysicsHeader>* newRec 
    = new RecDataRecord<RecPhysicsHeader>(*newHdr);

  // Objects pushed in snarl have periodicity of 3 snarls:
  // 0) No components
  // 1) An object TNamed w/objectname MyObject1
  // 2) Two objects i)TNamed w/objectname MyObject1
  //               ii)TNamed w/objectname MyObject2
  // This is to be able to test the HasComponent feature
  if ( rawHdr->GetSnarl() % 3 == 1 || rawHdr->GetSnarl() % 3 == 2 ) {
    TNamed* named = new TNamed("MyObject1","");
    newRec->AdoptComponent(named); 
  }  
  if ( rawHdr->GetSnarl() % 3 == 2 ) {
    TNamed* named = new TNamed("MyObject2","");
    newRec->AdoptComponent(named);
  }
 
  // And pass it to Mom, mom now has memory management responsibility
  MSG("DemoRecord",Msg::kInfo) 
    << "DemoRecordModule::Reco created record:\n" << *newRec << endl;
  mom->AdoptFragment(newRec);

  return result;

}

void DemoRecordModule::BeginJob() {
  //
  //  Purpose:  Configure module at beginning of job.
  //
  //  Arguments: none.
  //  
  //  Return: none.
  //
  //  Contact:   S. Kasahara
  // 

  MSG("DemoRecord", Msg::kVerbose) << "DemoRecordModule::BeginJob" << endl;

  // Configure module
 
}

void DemoRecordModule::Config(const Registry& r) {
  //
  //  Purpose:  Configure the module based on the contents of the registry.
  //
  //  Arguments: none.
  //  
  //  Return: none.
  //
  //  Contact:   S. Kasahara
  // 

  MSG("DemoRecord",Msg::kDebug) << "Config DemoRecordModule with r=" << r << endl;

}

const Registry& DemoRecordModule::DefaultConfig() const {
  //
  //  Purpose:  Load default values into configuration registry.
  //
  //  Arguments: none.
  //  
  //  Return: registry of default configuration values.
  //
  //  Contact:   S. Kasahara
  // 

  static Registry r;
  r.SetName("DemoRecord.config");

  r.UnLockValues();

  MSG("DemoRecord",Msg::kDebug) << "Loading default config.\n" << endl;

  // r.Set("variable","argument");

  r.LockValues();
  return r;

}

DemoRecordModule::DemoRecordModule() { 
  //
  //  Purpose:  Default constructor.
  //
  //  Arguments: none.
  //
  //  Return:    n/a.
  //
  //  Contact:   S. Kasahara
  // 
  //  Notes: none.
  // 

  MSG("DemoRecord", Msg::kVerbose) << "DemoRecordModule::Constructor" << endl;

}

DemoRecordModule::~DemoRecordModule() {
  //
  //  Purpose:  Destructor.  
  //
  //  Contact:   S. Kasahara
  // 

  MSG("DemoRecord", Msg::kVerbose) << "DemoRecordModule::Destructor" << endl;

}

---