HarpoReaderBase.cxx

Go to the documentation of this file.

// 
// File HarpoReaderBase.cxx
//
#include "HarpoReaderBase.h"
#include "HarpoDetReader.h"
#include "HarpoConfig.h"
#include "HarpoRunHeader.h"
#include "HarpoEvent.h"
#include "HarpoTimeStamp.h"

#include "HarpoDccReader.h"
#include "HarpoSimReader.h"

#include <climits>
#include <cstdio>
#include <arpa/inet.h>
//#include <cstdlib>
//#include <cstring>
#include <iostream>


ClassImp(HarpoReaderBase)


HarpoReaderBase::HarpoReaderBase()
{
  if(gHarpoDebug>0) Info("HarpoReaderBase()"," ");

  fRunNo = 0;
  fNevts = 0;
  fDone = false;
  fError = false;
  fMaxEvents = LONG_MAX;

  fNanalyses = 0;

  fDetReader = new HarpoDetReader *[gkNDetectors]; //Pointers to readers

  fEvent = (HarpoEvent *) NULL;
  fEventHeader = (HarpoEventHeader *) NULL;
  fRunHeader = (HarpoRunHeader *) NULL;

  //fAnalyse = (HarpoAnalyse *) NULL;
  //fAnalyse = (HarpoAnalyse *) NULL;
  //  fAnalyse.reserve(10);
  fDetSet = HarpoDetSet::Instance();
}


HarpoReaderBase::HarpoReaderBase(HarpoConfig *cfg) {
  if(gHarpoDebug>0) Info("HarpoReaderBase(cfg)"," ");
  // Config Function
  fRunNo = 0;
  fNevts = 0;

  fNanalyses = 0;

  fDone = false;
  fError = false;

  fDetReader = new HarpoDetReader *[gkNDetectors]; //Pointers to readers

  fMaxEvents = cfg->GetMaxEvents();
  fRunNo = cfg->GetRunNo();
  fFirstEvent = cfg->GetFromEvent();

  fEvent = (HarpoEvent *) NULL;
  fEventHeader = (HarpoEventHeader *) NULL;
  fRunHeader = (HarpoRunHeader *) NULL;

  // fAnalyse = (HarpoAnalyse *) NULL;
  //fAnalyse.reserve(10);
  
  fDetSet = HarpoDetSet::Instance();

}

HarpoReaderBase::~HarpoReaderBase()
{
  if(gHarpoDebug>0) Info("~HarpoReaderBase()"," ");
  delete [] fDetReader;
}

void HarpoReaderBase::SetAnalyseFunction(HarpoAnalyse *func, Int_t i)
{
  if(gHarpoDebug>0) Info("SetAnalyseFunction"," ");
  if(i<=fNanalyses) {
    fAnalyse[i] = func;
  } else { 
    Warning(__FUNCTION__,
            "Attempt to Set Analyse %d with %d defined, skeeping\n",
            i,fNanalyses);
  }

  if(( i==fNanalyses) && (fNanalyses < 29))
    fNanalyses++;
  else
  {
    Warning(__FUNCTION__,
            "NO Spasce  inAnalyses Array %d\n",fNanalyses);
  }
  // if ( fNanalyses ==  fAnalyse.size() ) {
  //   if(gHarpoDebug>0) Info(__FUNCTION__,"fAnalyse new size %d\n",(fNanalyses * 2));
  //   fAnalyse.resize(fNanalyses * 2);
  //}
}

void HarpoReaderBase::AddAnalyseFunction(HarpoAnalyse *func)
{
  if(gHarpoDebug>0) Info("SetAnalyseFunction"," ");

  if ( fNanalyses < 29 ) {
  fAnalyse[fNanalyses] = func;
  fNanalyses++;
  } else {
    Warning(__FUNCTION__,
            "NO Spasce in Analyses Array %d\n",fNanalyses);
  }

  // if ( fNanalyses ==  fAnalyse.size() ) {
  //   if(gHarpoDebug>0) Info(__FUNCTION__,"fAnalyse new size %d\n",(fNanalyses * 2));
  //   fAnalyse.resize(fNanalyses * 2);
  //}
}
  

Long_t      HarpoReaderBase::LoopAll()
{
  Long_t maxevents = fMaxEvents;
  if(gHarpoDebug>0) Info("Loop", "maxevents = %ld",maxevents);
  return Loop(maxevents);
}