ana.cc

Go to the documentation of this file.

#include <list>
#include <string>
#include <csignal>
#include <fstream>
#include "TROOT.h"
#include "TApplication.h"
#include "TRint.h"
#include "JobControl/jobc.h"
#include "XMLInterface/xmli.h"
#include "Config/Table.h"

static TROOT troot("ana","ana");

TFile* gsHistoFile = 0;

static void gsSIGHUPhandler(int s) 
{
  switch (s) {
  case SIGINT: case SIGQUIT: case SIGTERM: case SIGHUP:
    jobc::CmdLine::Instance().SetSIGHUP();
    break;

  case SIGUSR1:
    jobc::Sequence::PrintCurrentNode();
    break;

  default:
    break;
  }
}

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

int main(int argc, char** argv) 
{
  /* TRint* theApp = */ new TRint("ana",0,0);

  jobc::CmdLine::Instance().Parse(argc, argv);
  jobc::HistoFile::SetFileName(jobc::CmdLine::Instance().HistoFileName());

  // Start the XML parser and load files and directories specified on
  // the command line
  xmli::Initialize();

  std::list<std::string>::const_iterator itr;
  std::list<std::string>::const_iterator itrEnd;

  itr    = jobc::CmdLine::Instance().XMLFileList().begin();
  itrEnd = jobc::CmdLine::Instance().XMLFileList().end();
  for (; itr!=itrEnd; ++itr) xmli::ReadFile((*itr).c_str());

  itr    = jobc::CmdLine::Instance().XMLDirList().begin();
  itrEnd = jobc::CmdLine::Instance().XMLDirList().end();
  for (; itr!=itrEnd; ++itr) xmli::ReadDirectory((*itr).c_str());
  
  // Set the handler for the SIGHUP signal. Signal ends the job
  // gracefully at end of event currently being processed
  signal(SIGINT, gsSIGHUPhandler);
  signal(SIGQUIT,gsSIGHUPhandler);
  signal(SIGTERM,gsSIGHUPhandler);
  signal(SIGHUP, gsSIGHUPhandler);
  signal(SIGUSR1,gsSIGHUPhandler);

  // Dump the configuration before we start
  if ( strcmp(jobc::CmdLine::Instance().XMLDumpFile(),"") != 0 ) {
    std::ofstream file;
    file.open(jobc::CmdLine::Instance().XMLDumpFile());
    file << jobc::XMLConfiguration() << std::endl;
    file.close();
  }

  // Run all the jobs in the stack
  jobc::Stack::Instance().Run();
  jobc::Stack::Instance().CleanUp();

  // Clean up the histogram file
  if (jobc::HistoFile::File()) {
    jobc::HistoFile::File()->Write();
    jobc::HistoFile::File()->Close();
    if (! jobc::HistoFile::SaveHistos()) {  // JMP: this is a total hack;
      // if someone else knows how to nicely avoid writing out the histograms
      // and ntuples owned by the modules, please make the change to the code.
      std::string cmd("rm -f ");
      cmd += std::string(jobc::HistoFile::FileName());
      system(cmd.c_str());
    }
  }
  
  return 0;
}

---