manalyzer_example_esoteric.cxx

Go to the documentation of this file.

//
// MIDAS analyzer esoteric examples
//
// K.Olchanski
//
 
#include <stdio.h>
 
#include "manalyzer.h"
#include "midasio.h"
 
#ifdef HAVE_MIDAS
#include "odbxx.h"
#endif
 
static void PrintRunInfo(MVOdb* odb)
{
      uint32_t run_start_time_binary = 0;
      odb->RU32("Runinfo/Start time binary", &run_start_time_binary);
      time_t run_start_time = run_start_time_binary;
      printf("ODB Run start time: %d: %s", (int)run_start_time, ctime(&run_start_time));
 
      uint32_t run_stop_time_binary = 0;
      odb->RU32("Runinfo/Stop time binary", &run_stop_time_binary);
      if (run_stop_time_binary != 0) {
         time_t run_stop_time = run_stop_time_binary;
         printf("ODB Run stop  time: %d: %s", (int)run_stop_time, ctime(&run_stop_time));
      } else {
         printf("ODB Run stop  time: 0\n");
      }
}
 
static void PrintOdbXX()
{
#ifdef HAVE_MIDAS
   int start_time = midas::odb("/Runinfo/Start time binary");
   int stop_time  = midas::odb("/Runinfo/Stop time binary");
   printf("odbxx run start time: %d, run stop time: %d\n", start_time, stop_time);
 
#if 0
   while (1) {
      int time = midas::odb("/Runinfo/Start time binary");
      printf("time %d\n", time);
   }
#endif
 
#endif
}
 
struct ExampleE1: public TARunObject
{
   ExampleE1(TARunInfo* runinfo)
      : TARunObject(runinfo)
   {
      printf("ExampleE1::ctor, run %d, file %s\n", runinfo->fRunNo, runinfo->fFileName.c_str());
      fModuleName = "ExampleE1";
      fModuleOrder = 1;
      printf("runinfo BorOdbDump: %zu, EorOdbDump: %zu\n", runinfo->fBorOdbDump.size(), runinfo->fEorOdbDump.size());
 
#ifdef HAVE_ROOT
      if (runinfo->fRoot) {
         //runinfo->fRoot->fgUserOutputDirectory.clear();
         runinfo->fRoot->fOutputFileName = "my_custom_file_name.root";
         //runinfo->fRoot->fOutputFileName.clear();
      }
#endif
   }
 
   ~ExampleE1()
   {
      printf("ExampleE1::dtor!\n");
   }
 
   void BeginRun(TARunInfo* runinfo)
   {
      printf("ExampleE1::BeginRun, run %d, file %s\n", runinfo->fRunNo, runinfo->fFileName.c_str());
      printf("runinfo BorOdbDump: %zu, EorOdbDump: %zu\n", runinfo->fBorOdbDump.size(), runinfo->fEorOdbDump.size());
      //printf("runinfo BorOdbDump: %s\n", runinfo->fBorOdbDump.data());
      //printf("runinfo EorOdbDump: %s\n", runinfo->fEorOdbDump.data());
      PrintRunInfo(runinfo->fOdb);
      PrintOdbXX();
   }
 
   void PreEndRun(TARunInfo* runinfo)
   {
      printf("ExampleE1::PreEndRun, run %d\n", runinfo->fRunNo);
      printf("runinfo BorOdbDump: %zu, EorOdbDump: %zu\n", runinfo->fBorOdbDump.size(), runinfo->fEorOdbDump.size());
      PrintRunInfo(runinfo->fOdb);
      PrintOdbXX();
   }
 
   void EndRun(TARunInfo* runinfo)
   {
      printf("ExampleE1::EndRun, run %d\n", runinfo->fRunNo);
      printf("runinfo BorOdbDump: %zu, EorOdbDump: %zu\n", runinfo->fBorOdbDump.size(), runinfo->fEorOdbDump.size());
      PrintRunInfo(runinfo->fOdb);
      PrintOdbXX();
   }
 
   void PauseRun(TARunInfo* runinfo)
   {
      printf("ExampleE1::PauseRun, run %d\n", runinfo->fRunNo);
   }
 
   void ResumeRun(TARunInfo* runinfo)
   {
      printf("ExampleE1::ResumeRun, run %d\n", runinfo->fRunNo);
   }
 
   TAFlowEvent* Analyze(TARunInfo* runinfo, TMEvent* event, TAFlags* flags, TAFlowEvent* flow)
   {
      //printf("ExampleE1::Analyze, run %d, event serno %d, id 0x%04x, data size %d\n", runinfo->fRunNo, event->serial_number, (int)event->event_id, event->data_size);
      //PrintOdbXX();
      return flow;
   }
 
   void AnalyzeSpecialEvent(TARunInfo* runinfo, TMEvent* event)
   {
      printf("ExampleE1::AnalyzeSpecialEvent, run %d, event serno %d, id 0x%04x, data size %d\n", runinfo->fRunNo, event->serial_number, (int)event->event_id, event->data_size);
      printf("runinfo BorOdbDump: %zu, EorOdbDump: %zu\n", runinfo->fBorOdbDump.size(), runinfo->fEorOdbDump.size());
      PrintRunInfo(runinfo->fOdb);
      PrintOdbXX();
   }
};
 
struct ExampleE2: public TARunObject
{
   ExampleE2(TARunInfo* runinfo)
      : TARunObject(runinfo)
   {
      printf("ExampleE2::ctor, run %d, file %s\n", runinfo->fRunNo, runinfo->fFileName.c_str());
      fModuleName = "ExampleE2";
      fModuleOrder = 2;
   }
 
   ~ExampleE2()
   {
      printf("ExampleE2::dtor!\n");
   }
 
   void BeginRun(TARunInfo* runinfo)
   {
      printf("ExampleE2::BeginRun, run %d, file %s\n", runinfo->fRunNo, runinfo->fFileName.c_str());
      PrintOdbXX();
   }
 
   void PreEndRun(TARunInfo* runinfo)
   {
      printf("ExampleE2::PreEndRun, run %d\n", runinfo->fRunNo);
      PrintOdbXX();
   }
 
   void EndRun(TARunInfo* runinfo)
   {
      printf("ExampleE2::EndRun, run %d\n", runinfo->fRunNo);
      PrintOdbXX();
   }
 
   void PauseRun(TARunInfo* runinfo)
   {
      printf("ExampleE2::PauseRun, run %d\n", runinfo->fRunNo);
   }
 
   void ResumeRun(TARunInfo* runinfo)
   {
      printf("ExampleE2::ResumeRun, run %d\n", runinfo->fRunNo);
   }
 
   TAFlowEvent* Analyze(TARunInfo* runinfo, TMEvent* event, TAFlags* flags, TAFlowEvent* flow)
   {
      //printf("ExampleE2::Analyze, run %d, event serno %d, id 0x%04x, data size %d\n", runinfo->fRunNo, event->serial_number, (int)event->event_id, event->data_size);
      //PrintOdbXX();
      return flow;
   }
 
   void AnalyzeSpecialEvent(TARunInfo* runinfo, TMEvent* event)
   {
      printf("ExampleE2::AnalyzeSpecialEvent, run %d, event serno %d, id 0x%04x, data size %d\n", runinfo->fRunNo, event->serial_number, (int)event->event_id, event->data_size);
      printf("runinfo BorOdbDump: %zu, EorOdbDump: %zu\n", runinfo->fBorOdbDump.size(), runinfo->fEorOdbDump.size());
      PrintOdbXX();
   }
};
 
class ExampleE1Factory: public TAFactory
{
public:
   void Init(const std::vector<std::string> &args)
   {
      printf("ExampleE1::Init!\n");
   }
      
   void Finish()
   {
      printf("ExampleE1::Finish!\n");
   }
      
   TARunObject* NewRunObject(TARunInfo* runinfo)
   {
      printf("ExampleE1::NewRunObject, run %d, file %s\n", runinfo->fRunNo, runinfo->fFileName.c_str());
      return new ExampleE1(runinfo);
   }
};
 
class ExampleE2Factory: public TAFactory
{
public:
   void Init(const std::vector<std::string> &args)
   {
      printf("ExampleE2::Init!\n");
   }
      
   void Finish()
   {
      printf("ExampleE2::Finish!\n");
   }
      
   TARunObject* NewRunObject(TARunInfo* runinfo)
   {
      printf("ExampleE2::NewRunObject, run %d, file %s\n", runinfo->fRunNo, runinfo->fFileName.c_str());
      return new ExampleE2(runinfo);
   }
};
 
static TARegister tar1(new ExampleE1Factory);
static TARegister tar2(new ExampleE2Factory);
 
/* emacs
 * Local Variables:
 * tab-width: 8
 * c-basic-offset: 3
 * indent-tabs-mode: nil
 * End:
 */