JobCDemoModuleA.cxx

Go to the documentation of this file.

// $Id: JobCDemoModuleA.cxx,v 1.10 2002/07/17 14:09:13 rhatcher Exp $
//
// Empty implementation of a job module
//
// messier@huhepl.harvard.edu
#include "JobControl/test/JobCDemoModuleA.h"
#include "MessageService/MsgService.h"
#include "JobControl/JobCommand.h"
#include "JobControl/JobCEnv.h"
#include "JobControl/JobCModuleRegistry.h" // For JOBMODULE macro

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

CVSID("$Id: JobCDemoModuleA.cxx,v 1.10 2002/07/17 14:09:13 rhatcher Exp $");

// Declare this module to JobControll. Arguments are:
//  (1) The class name 
//  (2) The human-readable name 
//  (3) A short, human-readable description of what the module does
JOBMODULE(JobCDemoModuleA, 
          "DemoA",
          "A dummy module used for testing the JobControl package");

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

JobCDemoModuleA::JobCDemoModuleA() : fNget(0),fNana(0),fNreco(0)
{
  MSG("JobC", Msg::kDebug) << "** DemoModuleA::Constructor\n";
}

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

JobCDemoModuleA::~JobCDemoModuleA() 
{
  MSG("JobC", Msg::kDebug) << "** DemoModuleA::Destructor\n";
}

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

const Registry& JobCDemoModuleA::DefaultConfig() const
{
//======================================================================
// Setup the default configuration for the module
//======================================================================
  static Registry r;
  r.UnLockValues();
  r.SetName("DemoA.config");
  r.Set("Sweet",  16);  
  r.Set("Pi",     3.14);
  r.Set("OutFile","output.root");
  r.LockValues();
  return r;
}

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

void JobCDemoModuleA::Config(const Registry& r) 
{
//======================================================================
// Dummy config method.
//======================================================================
  MsgStream& m = MSGSTREAM("JobC",Msg::kInfo);
  m << "DemoA::Config()\n";
  if (r.KeyExists("Sweet")) { 
    m << " New value of Sweet = " << r.GetInt("Sweet") << "\n";
  }
  if (r.KeyExists("Pi")) {
    m << " New value of Pi = " << r.GetDouble("Pi") << "\n";
  }
  if (r.KeyExists("OutFile")) {
    m << " New value of OutFile = " << r.GetCharString("OutFile") << "\n";
  }
}

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

void JobCDemoModuleA::BeginJob() 
{
  MSG("JobC", Msg::kInfo) << "** DemoModuleA::BeginJob()\n";
}

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

void JobCDemoModuleA::EndJob() 
{
  MSG("JobC", Msg::kInfo) << "** DemoModuleA::EndJob()\n";
}

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

void JobCDemoModuleA::BeginFile()
{
  MSG("JobC", Msg::kInfo) << "** DemoModuleA::BeginFile()\n";
}

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

void JobCDemoModuleA::EndFile()
{
  MSG("JobC", Msg::kInfo) << "** DemoModuleA::EndFile()\n";
}

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

void JobCDemoModuleA::BeginRun()
{
  MSG("JobC", Msg::kInfo) << "** DemoModuleA::BeginRun()\n";
}

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

void JobCDemoModuleA::EndRun()
{
  MSG("JobC", Msg::kInfo) << "** DemoModuleA::EndRun()\n";
}

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

JobCResult JobCDemoModuleA::Get(MomNavigator *mom)
{
  ++fNget;
  MSG("JobC", Msg::kInfo) << 
    "** DemoModuleA::Get (" << mom << ") nGet=" << fNget << "\n";
  
  // Practice sending some typical results
  JobCResult r;
  // Begin/End File
  if (fNget%5 == 1) {
    r.SetBeginFile();
    if (fNget>1) r.SetEndFile();
  }
  // Begin/End Run
  if (fNget%10 == 1) {
    r.SetBeginRun();
    if (fNget>1) r.SetEndRun();
  }
  // End of input stream
  if (fNget > 30) {
    r.SetEndOfInputStream();
  }
  return r;
}

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

JobCResult JobCDemoModuleA::Ana(const MomNavigator *mom)
{
  ++fNana;
  
  MSG("JobC", Msg::kInfo)
    << "** DemoModuleA(" << this << ")::Ana (" << mom << ")" 
    << " Ana=" << fNana << "\n";
  
  return JobCResult::kAOK;
}

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

JobCResult JobCDemoModuleA::Reco(MomNavigator *mom)
{
  ++fNreco;
  MSG("JobC", Msg::kInfo) << 
    "** DemoModuleA(" << this << ")::Reco(" << mom << ") nReco=" << 
    fNreco << "\n";
  if (fNreco%2 == 0) return JobCResult::kPassed;
  return JobCResult::kFailed;
}

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

void JobCDemoModuleA::HandleCommand(JobCommand* c) 
{
  MsgStream& m = MSGSTREAM("JobC", Msg::kInfo);

  bool ifirst = true;
  m << "** DemoModuleA::HandleCommand: ";
  while (c->HaveCmd()) {
    if (!ifirst) m << "/";
    m << c->PopCmd();
    ifirst = false;
  }
  m << " opt={";
  ifirst = true;
  while (c->HaveOpt()) {
    if (!ifirst) m << ",";
    m << c->PopOpt();
    ifirst = false;
  }
  m << "}\n";
}

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

void JobCDemoModuleA::Help() 
{
  MSG("JobC", Msg::kInfo) << "** DemoModuleA::Help()\n";
}

---