spadicplugin/go4/TSpadicAnalysis.cxx (r4864/r3721)

Go to the documentation of this file.

#include "TSpadicAnalysis.h"

#include <stdlib.h>

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

//***********************************************************
TSpadicAnalysis::TSpadicAnalysis() :
   fMbsEvent(0),
   fEvents(0),
   fLastEvent(0)
{
}
//***********************************************************

// this constructor is called by go4analysis executable
TSpadicAnalysis::TSpadicAnalysis(int argc, char** argv) :
   TGo4Analysis(argc, argv),
   fMbsEvent(0),
   fEvents(0),
   fLastEvent(0)
{
   TGo4Log::Info("Create TSpadicAnalysis name: %s", argv[0]);

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

   TGo4StepFactory* factory = new TGo4StepFactory("Factory");
   factory->DefEventProcessor("SpadicProc","TSpadicProc");// object name, class name
   factory->DefOutputEvent("SpadicEvent","TSpadicEvent"); // object name, class name

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

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

   TGo4AnalysisStep* step = new TGo4AnalysisStep("Analysis", 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("Spadicadmin", "Spadicctrl", "Spadicview");

   
}

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

//-----------------------------------------------------------
Int_t TSpadicAnalysis::UserPreLoop()
{
   // all this is optional:
   cout << "**** TSpadicAnalysis: PreLoop" << endl;
   // get pointer to input event (used in postloop and event function):
   fMbsEvent = dynamic_cast<TGo4MbsEvent*> (GetInputEvent("Analysis"));   // of step "Analysis"
   if(fMbsEvent) {
      // fileheader structure (lmd file only):
      s_filhe* fileheader=fMbsEvent->GetMbsSourceHeader();
      if(fileheader)
      {
         cout <<"\nInput file: "<<fileheader->filhe_file << endl;
         cout <<"Tapelabel:\t" << fileheader->filhe_label<<endl;
         cout <<"UserName:\t" << fileheader->filhe_user<<endl;
         cout <<"RunID:\t" << fileheader->filhe_run<<endl;
         cout <<"Explanation: "<<fileheader->filhe_exp <<endl;
         cout <<"Comments: "<<endl;
         Int_t numlines=fileheader->filhe_lines;
         for(Int_t i=0; i<numlines;++i)
         {
            cout<<"\t"<<fileheader->s_strings[i].string << endl;
         }
      }
   }
   fEvents=0; // event counter
   fLastEvent=0; // number of last event processed
   return 0;
}
//-----------------------------------------------------------
Int_t TSpadicAnalysis::UserPostLoop()
{
   // all this is optional:
   TGo4Log::Info("TSpadicAnalysis: PostLoop");
   TGo4Log::Info("Last event  #: %d Total events: %d", fLastEvent, fEvents);
   fMbsEvent = 0; // reset to avoid invalid pointer if analysis is changed in between
   fEvents=0;
   return 0;
}

//-----------------------------------------------------------
Int_t TSpadicAnalysis::UserEventFunc()
{
   // all this is optional:
   // This function is called once for each event after all steps.
   if(fMbsEvent) {
      fEvents++;
      fLastEvent=fMbsEvent->GetCount();
   }
   if(fEvents == 1 || IsNewInputFile()) {
      TGo4Log::Info("First event #: %d", fLastEvent);
      SetNewInputFile(kFALSE); // we have to reset the newfile flag
   }
   return 0;
}