HarpoDetReader.cxx

Go to the documentation of this file.

// 
// File HarpoDetReader.cxx
//
#include "HarpoDetReader.h"
#include "HarpoDet.h"
#include "HarpoDebug.h"
#include <TSystem.h>

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

ClassImp(HarpoDetReader)


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

  fRunNo = 0;
  fDet = -1;

  fInFile = (TString *) NULL;
  //fIn = (FILE *) NULL;
  fNevts = 0;

  // fNewFile = (TFile *) NULL;
  // fNewNb = 0;

  fEvent = (HarpoDetEvent *) NULL;
  fRunHeader = (HarpoDetHeader *) NULL;

  fMaxEvents = LONG_MAX;
  fPrevTimeStamp = 0;
  isEventSaved = false;

}


HarpoDetReader::HarpoDetReader(HarpoConfig *cfg) {
  // Config Function
  fRunNo = cfg->GetRunNo();
  fInFile = cfg->GetInFile(0);
  //fIn = (FILE *) NULL;
  fNevts = 0;
  fMaxEvents = cfg->GetMaxEvents();

  //  fNewNb = 0;

  fEvent = (HarpoDetEvent *) NULL;
  fRunHeader = (HarpoDetHeader *) NULL;

  fPrevTimeStamp = 0;
  isEventSaved = false;
}

HarpoDetReader::~HarpoDetReader()
{
  //std::fclose(fIn);
  delete fRunHeader;
}

void HarpoDetReader::SetDetFile(TString *name)
{
  fInFile = name;
}

// void HarpoDetReader::SetRootFile(TString *name)
// {
//   fNewFileName = name; 
//   fNewFile = new TFile(name->Data(),"RECREATE","HARPO Det Events");
// }

HarpoDetEvent *HarpoDetReader::GetEvent()
{
  if(gHarpoDebug>1) Info("GetEvent","%p",(void *)fEvent); 
  return fEvent;
}

HarpoDetHeader *HarpoDetReader::GetDetHeader()
{
  if(gHarpoDebug>1) Info("GetDetHeader"," ");
  return fRunHeader;
}


// Bool_t HarpoDetReader::Init()
// {
  // const char * fn = fInFile->Data();
  // std::cout << " Init " << fn << std::endl;
  // if ( fInFile->BeginsWith("/" )) { // full path 
  //   if ( gSystem->AccessPathName(fn,kReadPermission) ) {
  //     perror("Det File access");
  //     return false;
  //   }
  // } else {
  //   if (  gSystem->AccessPathName(fn,kReadPermission) ) { // file not exist
  //     // TODO
  //     //  TString *DataDir = gHDetCfg->GetDataDir();
  //     // Not a best way but i can't use config hire
  //     TString DataDir(gSystem->Getenv("HARPO_DATA_DIR"));
      
  //     if ( ! DataDir.EndsWith("/") ) DataDir.Append("/");
  //     fInFile->Prepend(DataDir);
  //     fn = fInFile->Data();
  //     if ( gSystem->AccessPathName(fn,kReadPermission) ) {
  //    perror("Det File access");
  //    return false;
  //     }
  //   }
  // }
  
  // std::cout << " Guessed " << fn << std::endl;
    
  // fIn = std::fopen(fn,"r");
  // if ( fIn != NULL ) {
  //     fRunHeader = new HarpoDetHeader(fIn);
  //     fRunHeader->check();
  //     return fRunHeader->check();
  // } else { 
  //   perror("Det File open");
  //   return false;
  // }
//   return false;
// }
  

Bool_t  HarpoDetReader::Find(Long_t eventNo)
{
  Long_t cnt=0;
  Long_t maxevents = fMaxEvents;
  Bool_t found = false;
  HarpoDetEvent *evt;
  if(gHarpoDebug>0) Info("Find","%ld",eventNo);

  while (NextEvent()) {
    evt = GetEvent();  // Read Event
    if(gHarpoDebug>1) Info("Find val","%ld in evt %d",
                           eventNo,(evt->GetHeader())->eventNumb);
    if ((evt->GetHeader())->eventNumb == eventNo) {
      found = true;
      break;
    }
    SkipEvent();
    if (++cnt >= maxevents) break;
  }
  return found;
}

void  HarpoDetReader::SkipEvent()
{
  if(gHarpoDebug>1) {
    HarpoDet dt(fDet);
    Info("SkipEvent","%s, evt %ld",dt.GetName(), fNevts);
  }
  //isEventSaved = false;
  HarpoDetEvent *evt = GetEvent(); // We need read event data
  if ( evt != NULL ) delete evt ; // We will not process this event,
                                  // return NULL  on read arror
}

void  HarpoDetReader::PushBack()
{
  fSaveEvent = fEvent;
  fEvent = NULL; 
  isEventSaved = true;
  if(gHarpoDebug>1) {
    HarpoDet dt(fDet);
    Info("PushBack","%s (%ld), evt %ld",dt.GetName(), fDet, fNevts);
  }
}