ORKatrinFLTWaveformTreeWriter.cc

// ORKatrinFLTWaveformTreeWriter.cc

#include "ORKatrinFLTWaveformTreeWriter.hh"
#include "ORLogger.hh"
#include "ORUtils.hh"

using namespace std;

ORKatrinFLTWaveformTreeWriter::ORKatrinFLTWaveformTreeWriter(string treeName) :
ORVTreeWriter(new ORKatrinFLTWaveformDecoder, treeName)
{
  fEventDecoder = dynamic_cast<ORKatrinFLTWaveformDecoder*>(fDataDecoder);
  Clear();
  fWaveform[0] = 0;  // this is on the stack, not the heap.
}

ORKatrinFLTWaveformTreeWriter::~ORKatrinFLTWaveformTreeWriter()
{
  delete fEventDecoder;
}

/** Create the ROOT branches.
  * 
  */ //-tb- 2008-02-12
ORDataProcessor::EReturnCode ORKatrinFLTWaveformTreeWriter::InitializeBranches()
{
  fTree->Branch("wfLength", &fWaveformLength, "wfLength/i");
  fTree->Branch("eventSec", &fSec, "eventSec/i");
  fTree->Branch("eventSubSec", &fSubSec, "eventSubSec/i");
  fTree->Branch("eventID", &fEventID, "eventID/s");
  fTree->Branch("crate", &fCrate, "crate/s");
  fTree->Branch("card", &fCard, "card/s");
  fTree->Branch("channel", &fChannel, "channel/s");
  fTree->Branch("channelMap", &fChannelMap, "channelMap/s");
  fTree->Branch("pageNumber", &fPageNumber, "pageNumber/s");
  fTree->Branch("energy_adc", &fEnergy, "energy_adc/i");
  fTree->Branch("resetSec", &fResetSec, "resetSec/i");
  fTree->Branch("resetSubSec", &fResetSubSec, "resetSubSec/i");
  fTree->Branch("waveform", fWaveform, "waveform[wfLength]/s");
  return kSuccess;
}

/**  This sets the data/variables for the ROOT branches.
  *  TTree::Fill() is called in ORBasicTreeWriter::ProcessMyDataRecord(UInt_t* record) (?)
  *  This class is a ORDataProcessor and ORVTreeWriter, NOT a ORBasicTreeWriter!
  *  (See comments in ORDataProcessor.hh and ORVTreeWriter.hh)
  */ //-tb- 2008-02-12
ORDataProcessor::EReturnCode ORKatrinFLTWaveformTreeWriter::ProcessMyDataRecord(UInt_t* record)
{
  // the event decoder could run into a problem, but this might not
  // ruin the rest of the run.
  if(!fEventDecoder->SetDataRecord(record)) return kFailure;
      // check severity to improve speed:
  fSec = fEventDecoder->GetSec();
  fSubSec = fEventDecoder->GetSubSec();
  fEventID = fEventDecoder->GetEventID();
  fEnergy = fEventDecoder->GetEnergy();
  fCrate = fEventDecoder->CrateOf();
  fCard = fEventDecoder->CardOf();
  fChannel = fEventDecoder->GetChannel();
  fChannelMap = fEventDecoder->GetChannelMap();
  fPageNumber = fEventDecoder->GetPageNumber();
  fWaveformLength = fEventDecoder->GetWaveformLen();
  fResetSec = fEventDecoder->GetResetSec();
  fResetSubSec = fEventDecoder->GetResetSubSec();
   
  if (ORLogger::GetSeverity() >= ORLogger::kDebug) 
  { 
    ORLog(kDebug) << "ProcessMyDataRecord(): "
      << "event-sec-subsec-crate-card-channel-energy_adc-resetsec-resetsubsec-chmap-pagenum = "
      << fEventID << "-" << fSec << "-" << fSubSec << "-" << fCrate << "-"
      << fCard << "-" << fChannel << "-" << fEnergy 
      << "-" << fResetSec << "-" << fResetSubSec   //-tb- 2008-02-12
      << "-" << fChannelMap << "-" << fPageNumber  //-tb- 2008-02-12
      << endl;
  }
  if(fWaveformLength > kMaxWFLength) {
    ORLog(kError) << "Waveform length (" << fWaveformLength 
      << ") exceeds kMaxWFLength (" << kMaxWFLength << ")" << endl;
    return kFailure;
  }
  
  fEventDecoder->CopyWaveformData( fWaveform, kMaxWFLength );

  return kSuccess;
}