beamtime/tof-tdctest/go4/TGsiAug12Analysis.cxx (r4864/r4277)

Go to the documentation of this file.

#include "TGsiAug12Analysis.h"

#include <stdlib.h>
#include "TGo4Version.h"
#if __GO4BUILDVERSION__ > 40502
   #include "go4iostream.h"
#else
   #include "Riostream.h"
#endif

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

#include "TGsiAug12Param.h"

//***********************************************************
TGsiAug12Analysis::TGsiAug12Analysis()
{
}
//***********************************************************

// this constructor is called by go4analysis executable
TGsiAug12Analysis::TGsiAug12Analysis(int argc, char** argv) :
   TGo4Analysis(argc, argv)
{
   cout << "**** Create TGsiAug12Analysis name: " << argv[0] << endl;

   if (!TGo4Version::CheckVersion(__GO4BUILDVERSION__)) {
      cout << "****  Go4 version mismatch" << endl;
      exit(-1);
   }

   TGo4StepFactory* factory = new TGo4StepFactory("Factory");
   factory->DefEventProcessor("GsiAug12UnpackProc","TGsiAug12UnpackProc");// object name, class name
   factory->DefOutputEvent("GsiAug12UnpackEvent","TGsiAug12UnpackEvent"); // object name, class name

   Text_t lmdfile[512]; // source file
   sprintf(lmdfile,"%s/data/test.lmd",getenv("GO4SYS"));
   TGo4EventSourceParameter* sourcepar = new TGo4MbsFileParameter(lmdfile);

   TGo4FileStoreParameter* storepar = new TGo4FileStoreParameter(Form("%sOutput", argv[0]));
   storepar->SetOverwriteMode(kTRUE);

   TGsiAug12Param* parAnalysis = (TGsiAug12Param*) MakeParameter("GsiAug12Par", "TGsiAug12Param");
   ExecuteScript("set_GsiAug12Par.C");

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

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

   AddAnalysisStep(step);

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

   if( kTRUE == parAnalysis->bWithVftxCalib )
   {
      TGo4StepFactory* factory2 = new TGo4StepFactory("Factory2");
      factory2->DefEventProcessor("GsiAug12CalibrationProc","TGsiAug12CalibrationProc");// object name, class name
      factory2->DefInputEvent("GsiAug12UnpackEvent","TGsiAug12UnpackEvent"); // object name, class name
      factory2->DefOutputEvent("GsiAug12CalibrationEvent","TGsiAug12CalibrationEvent"); // object name, class name

      TGo4AnalysisStep* step2 = new TGo4AnalysisStep("Calibration", factory2, 0, 0);

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

      AddAnalysisStep(step2);
   } // if( kTRUE == parAnalysis->bWithVftxCalib )

   if( kTRUE == parAnalysis->bWithScalersRate ||
       0 < parAnalysis->uNbRpc ||
       0 < parAnalysis->uNbPadRpc ||
       0 < parAnalysis->uNbPlastics )
   {
      TGo4StepFactory* factory3 = new TGo4StepFactory("Factory3");
      factory3->DefEventProcessor("GsiAug12DetectorProc","TGsiAug12DetectorProc");// object name, class name

      if( kTRUE == parAnalysis->bWithVftxCalib )
         factory3->DefInputEvent("GsiAug12CalibrationEvent","TGsiAug12CalibrationEvent"); // object name, class name
      else
         factory3->DefInputEvent("GsiAug12UnpackEvent","TGsiAug12UnpackEvent"); // object name, class name

      factory3->DefOutputEvent("GsiAug12DetectorEvent","TGsiAug12DetectorEvent"); // object name, class name

      TGo4AnalysisStep* step3 = new TGo4AnalysisStep("Detector", factory3, 0, 0);

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

      AddAnalysisStep(step3);
   } // if at least one detector

   if( kTRUE == parAnalysis->bWithMatching )
   {
      TGo4StepFactory* factory4 = new TGo4StepFactory("Factory4");
      factory4->DefEventProcessor("GsiAug12TrackingProc","TGsiAug12TrackingProc");// object name, class name
      factory4->DefInputEvent("GsiAug12DetectorEvent","TGsiAug12DetectorEvent"); // object name, class name
      factory4->DefOutputEvent("GsiAug12TrackingEvent","TGsiAug12TrackingEvent"); // object name, class name

      TGo4AnalysisStep* step4 = new TGo4AnalysisStep("Tracking", factory4, 0, 0);

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

      AddAnalysisStep(step4);
   } // if( kTRUE == parAnalysis->bWithMatching )

   if( kTRUE == parAnalysis->bWithTreeOutput )
   {
      // Attempt to have a Ouput Tree Formatting step
      TGo4StepFactory* factory5 = new TGo4StepFactory("Factory5");
      factory5->DefEventProcessor("GsiAug12OutputProc","TGsiAug12OutputProc");// object name, class name

      if( kTRUE == parAnalysis->bWithMatching )
         factory5->DefInputEvent("GsiAug12TrackingEvent","TGsiAug12TrackingEvent"); // object name, class name
      else if( kTRUE == parAnalysis->bWithScalersRate ||
               0 < parAnalysis->uNbRpc ||
               0 < parAnalysis->uNbPadRpc ||
               0 < parAnalysis->uNbPlastics )
         factory5->DefInputEvent("GsiAug12DetectorEvent","TGsiAug12DetectorEvent"); // object name, class name
      else if( kTRUE == parAnalysis->bWithVftxCalib )
         factory5->DefInputEvent("GsiAug12CalibrationEvent","TGsiAug12CalibrationEvent"); // object name, class name
      else factory5->DefInputEvent("GsiAug12UnpackEvent","TGsiAug12UnpackEvent"); // object name, class name

      factory5->DefOutputEvent("GsiAug12OutputEvent","TGsiAug12OutputEvent"); // object name, class name


      TGo4AnalysisStep* step5 = new TGo4AnalysisStep("Output", factory5, 0, 0);

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

      AddAnalysisStep(step5);
   } // if( kTRUE == parAnalysis->bWithTreeOutput )

   // uncomment following line to define custom passwords for analysis server
   // DefineServerPasswords("GsiAug12admin", "GsiAug12ctrl", "GsiAug12view");

}

//***********************************************************
TGsiAug12Analysis::~TGsiAug12Analysis()
{
   cout << "**** TGsiAug12Analysis: Delete instance" << endl;
}