onlinemonitor/rocmonitor/TRocAnalysis.cxx (r4864/r3724)

Go to the documentation of this file.

#include "TRocAnalysis.h"

#include <cstdlib>
#include <getopt.h>

#include "Go4EventServer.h"
#include "TGo4StepFactory.h"
#include "TGo4AnalysisStep.h"
#include "TGo4Version.h"
#include "TGo4Log.h"



//***********************************************************
TRocAnalysis::TRocAnalysis()
{
}
//***********************************************************

// this constructor is called by go4analysis executable
TRocAnalysis::TRocAnalysis(int argc, char** argv) :
   TGo4Analysis(argc, argv)
{
   if (!TGo4Version::CheckVersion(__GO4BUILDVERSION__)) {
      TGo4Log::Error("Go4 version mismatch");
      exit(-1);
   }

   TGo4Log::Info("Create TRocAnalysis name: %s", argv[0]);

   // parsing user arguments
   // see http://www.gnu.org/software/libc/manual/html_node/Getopt-Long-Option-Example.html#Getopt-Long-Option-Example
   // for details about getpar and more examples
   int c;
   while (1)
   {
           static struct option long_options[] =
           {
                   /* These options don't set a flag.
                        *                  We distinguish them by their indices. */
                   {"par",  required_argument, 0, 'p'},
                   {"cond",  required_argument, 0, 'c'},
                   {0, 0, 0, 0}
           };
           /* getopt_long stores the option index here. */
           int option_index = 0;
           
           c = getopt_long (argc, argv, "c:p:",
                                                long_options, &option_index);
           
           /* Detect the end of the options. */
           if (c == -1)
                   break;
           
           switch (c)
           {
                   case 'c':
                           userConds = optarg;
                           break;
                           
                   case 'p':
                           userPars = optarg;
                           break;

                   case '?':
                           /* getopt_long already printed an error message. */
                           break;

                   default:
                      TGo4Log::Error("No option %c. Check your arguments list. Aborting, sorry...", c);
                           abort();
           }
   }

   TGo4StepFactory* factory = new TGo4StepFactory("Factory");
   factory->DefEventProcessor("RocProc","TRocProc");// object name, class name
   factory->DefOutputEvent("ROC","TRocEvent"); // object name, class name
   factory->DefUserEventSource("TRocSource"); // object name, class name

   TGo4EventSourceParameter* sourcepar = new TGo4MbsFileParameter(Form("%s/data/test.lmd",getenv("GO4SYS")));
   TGo4FileStoreParameter* storepar = new TGo4FileStoreParameter(Form("%sOutput", argv[0]));
   storepar->SetOverwriteMode(kTRUE);

   TGo4AnalysisStep* step = new TGo4AnalysisStep("Roc", factory, sourcepar, storepar);

   step->SetSourceEnabled(kTRUE);
   step->SetStoreEnabled(kFALSE);
   step->SetProcessEnabled(kTRUE);
   step->SetErrorStopEnabled(kTRUE);

   // Now the first analysis step is set up.
   // Other steps could be created here
   AddAnalysisStep(step);

   // uncomment following line to define custom passwords for analysis server
   // DefineServerPasswords("CernOct11admin", "CernOct11ctrl", "CernOct11view");

}

//***********************************************************
TRocAnalysis::~TRocAnalysis()
{
   TGo4Log::Info("TRocAnalysis: Delete instance");
}