fmwk/JobControl/Module.cxx

Go to the documentation of this file.

#include "JobControl/Module.h"
#include "JobControl/Exception.h"
#include <iostream>
#include "Config/Config.h"
#include "Config/Table.h"
#include <unistd.h>
using namespace jobc;

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

Module::Module(const char*  name) :
  fName      ( name  ),
  fCfgVersion( ""    ),
  fIsInit    ( false )
{ }

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

Result Module::Reco(edm::EventHandle& /*evt*/)    { 
  char msg[256];
  sprintf(msg, "Calling default %s::Reco()", fName.c_str());

  assert_jobc(0, msg);

  return kPassed;
}

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

Result Module::Ana(const edm::EventHandle& /*ev*/)
{
  char msg[256];
  sprintf(msg, "Calling default %s::Ana()", fName.c_str());
  assert_jobc(0, msg);
  return kPassed;
}

void Module::NewFile(const char* /*filename*/)      { }
void Module::EndFile(const char* /*filename*/)      { }
void Module::NewRun(int /*run*/, int /*subrun*/)    { }
void Module::EndRun(int /*run*/, int /*subrun*/)    { }
void Module::NewSubrun(int /*run*/, int /*subrun*/) { }
void Module::EndSubrun(int /*run*/, int /*subrun*/) { }

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

void Module::Reset() { this->SetCfgVersion("default"); }

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

void Module::SetCfgVersion(const char* cfgv) 
{
  if (fCfgVersion == cfgv) return; // Nothing to do...
  this->RemoveWatch(fCfgVersion.c_str());
  fCfgVersion = cfgv;
  this->SetWatch(fName.c_str(), fCfgVersion.c_str());
  // std::cerr << "Set watch for " << this->Name() << cfgv << std::endl;
}

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

void Module::Report() 
{
  std::cout << fName << ": Nothing to report." << std::endl;
}

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

void Module::CheckInit()
{
  if (fIsInit) return;
  std::cout << "Module " << fName << "/" << fCfgVersion
       << " is not initialized. Stopping the job." << std::endl;
  exit(-1);
}

---