onlinemonitor/framework/TCBMBeamtimeProc.cxx (r4864/r3805)

Go to the documentation of this file.

#include "TCBMBeamtimeProc.h"

#include "TGo4Log.h"
#include "TSystem.h"
#include "TROOT.h"

TCBMBeamtimeProc::TCBMBeamtimeProc():
   TGo4EventProcessor(),
   fBeamtimeEvent(0),
   fMbsInput(0),
   fMbsTriggerNumber(0),
   fMbsEventNumber(0),
   fSubProcessors(0),
   fProcIterator(0)
{
} // streamer dummy


TCBMBeamtimeProc::TCBMBeamtimeProc(const char* name) :
   TGo4EventProcessor(name),
   fBeamtimeEvent(0),
   fMbsInput(0),
   fMbsTriggerNumber(0),
   fMbsEventNumber(0),
   fSubProcessors(0),
   fProcIterator(0)
{
   fSubProcessors = new TObjArray;
   fProcIterator = fSubProcessors->MakeIterator();
}

TCBMBeamtimeProc::~TCBMBeamtimeProc()
{

   delete fProcIterator;
   if(fSubProcessors) fSubProcessors->Delete();
   delete fSubProcessors;

}

void TCBMBeamtimeProc::AddSubProcessor(TCBMBeamtimeProc* proc)
{
   fSubProcessors->AddLast(proc);
}

void TCBMBeamtimeProc::ProcessSubevent(TGo4MbsSubEvent* subevt)
{
   //cout << "Dummy, should be reimplemented " << endl; // but must not if this is the top beamtime event JAM
}


Bool_t TCBMBeamtimeProc::BuildEvent(TGo4EventElement* outevnt)
{
   fBeamtimeEvent = dynamic_cast<TCBMBeamtimeEvent*>(outevnt);
   // if there is no container event as output, subclass may run in standalone mode
   InitEvent(outevnt); // for plain subclass mode

   // first need to call SetEvent of all subprocessors to set the input/output structures:
   fProcIterator->Reset();
   TCBMBeamtimeProc* proc=0;
   while((proc= dynamic_cast<TCBMBeamtimeProc*>( fProcIterator->Next() ) ) !=0)
   {
      proc->SetInputEvent(GetInputEvent()); //forward input to subprocessors
      proc->InitEvent(outevnt); // subprocessors may set own eventpointers here
   } // while

   // treat mbs input if we are in the first step:
   fMbsInput = dynamic_cast<TGo4MbsEvent*>(GetInputEvent());

//   printf("TCBMBeamtimeProc::BuildEvent this = %p name = %s evnt = %p \n", this, GetName(), fMbsInput);

   if(fMbsInput)
   {
//      if(fMbsInput->GetTrigger() > 11) {
//         cout << "**** TCBMBeamtimeProc: Skip trigger event"<<endl;
//         return kFALSE;

      fMbsTriggerNumber = fMbsInput->GetTrigger();
      fMbsEventNumber = fMbsInput->GetCount();

      TGo4MbsSubEvent* psubevt = 0;
      fMbsInput->ResetIterator();
      while((psubevt = fMbsInput->NextSubEvent()) != 0)
      { // loop over subevents
         ProcessSubevent(psubevt); // process in our own subclass, if implemented
         fProcIterator->Reset();
         while((proc = dynamic_cast<TCBMBeamtimeProc*>( fProcIterator->Next() ) ) !=0) {
            proc->fMbsTriggerNumber = fMbsTriggerNumber;
            proc->fMbsEventNumber = fMbsEventNumber;

            proc->ProcessSubevent(psubevt); // actions implemented in component subclass
         } // while proc
      } // whilesubevents
   } // mbs input


   // in any case, call finalize processing in all subclasses/components:
   // this is the way to implement actions in second step processors
   // for first step processors, this can be used to do actions after all subevents are done
   FinalizeEvent(); // process in our own subclass, if implemented
   fProcIterator->Reset();
   while((proc= dynamic_cast<TCBMBeamtimeProc*>( fProcIterator->Next() ) ) !=0)
      proc->FinalizeEvent(); // actions implemented in component subclass

#if __GO4BUILDVERSION__ > 40500
   Bool_t keepinput(kFALSE), keepoutput(kFALSE);

   // then evaluate subprocessors if any:
   fProcIterator->Reset();
   Bool_t standalonemode=kTRUE;
   while((proc= dynamic_cast<TCBMBeamtimeProc*>( fProcIterator->Next() ) ) !=0)
   {
      standalonemode=kFALSE;
      if(proc->IsKeepInputEvent()) keepinput=kTRUE;
      if(proc->IsKeepOutputEvent()) keepoutput=kTRUE;
   } // while proc
   if(standalonemode)
      {
          // preserve subclass keep buffer states if running in standalone analysis:
            if(IsKeepInputEvent()) keepinput=kTRUE;
            if(IsKeepOutputEvent()) keepoutput=kTRUE;
      }

   //cout <<"   TCBMBeamtimeProc::BuildEvent - keepinput is " << keepinput<< endl;
   SetKeepInputEvent(keepinput);
   SetKeepOutputEvent(keepoutput);
   // if one subprocessor did keep the input or output event, all are informed about this:
   fProcIterator->Reset();
   while ((proc = dynamic_cast<TCBMBeamtimeProc*>(fProcIterator->Next()))!= 0) {
      proc->SetKeepInputEvent(keepinput);
      proc->SetKeepOutputEvent(keepoutput);
   }
#endif

   return kTRUE;
}

#if __GO4BUILDVERSION__ < 40504

// this is only for short time, with new go4 version method will be included in to framework
Long_t TCBMBeamtimeProc::ExecuteScript(const char* script_name)
{
   if (gSystem->AccessPathName(script_name)) {
      TGo4Log::Info("NO setup script %s found", script_name);
      return -1;
   }

   TGo4Log::Info("Executing setup script %s", script_name);
   return gROOT->ProcessLineSync(Form(".x %s", script_name));
}

#endif