RdChannelNoiseASCIIExporter.cc

Go to the documentation of this file.

#include "RdChannelNoiseASCIIExporter.h"
#include <utl/ErrorLogger.h>

#include <evt/Event.h>
#include <revt/REvent.h>
#include <revt/Header.h>
#include <revt/Station.h>
#include <revt/Channel.h>

#include <utl/Trace.h>
#include <utl/TraceAlgorithm.h>
#include <utl/ErrorLogger.h>
#include <utl/Reader.h>
#include <utl/config.h>
#include <utl/AugerUnits.h>
#include <fwk/CentralConfig.h>

using namespace std;


using namespace std;
using namespace utl;
using namespace fwk;
using namespace revt;


namespace RdChannelNoiseASCIIExporter {

  RdChannelNoiseASCIIExporter::RdChannelNoiseASCIIExporter() : 
  fNumber(0),
  fNumberOfTracestoPrepare(0),
  fInfoLevel(0),
  fpath("")
  {
  }


  RdChannelNoiseASCIIExporter::~RdChannelNoiseASCIIExporter()
  {
  }


  VModule::ResultFlag
  RdChannelNoiseASCIIExporter::Init()
  {
    // Initialize your module here. This method 
    // is called once at the beginning of the run.
    // The eSuccess flag indicates the method ended
    // successfully.  For other possible return types, 
    // see the VModule documentation.

    INFO("RdChannelNoiseASCIIExporter::Init()");
    Branch topBranch = CentralConfig::GetInstance()->GetTopBranch("RdChannelNoiseASCIIExporter");
    topBranch.GetChild("NoiseFilePath").GetData(fpath);
    topBranch.GetChild("InfoLevel").GetData(fInfoLevel);
    topBranch.GetChild("firstNumber").GetData(fNumber);
    topBranch.GetChild("NumberOfTraces").GetData(fNumberOfTracestoPrepare);
    cout << " MM DEBUG " << fpath << " " << *(--fpath.end()) << endl; 
    if (fpath.compare(fpath.size()-1,fpath.size() ,"/")!=0)
      fpath.append("/");



    return eSuccess;
  }


  VModule::ResultFlag
  RdChannelNoiseASCIIExporter::Run(evt::Event& event)
  {

    INFO("RdChannelNoiseASCIIExporter::Run()");
    ++fNumber; 
    ostringstream fname; 
    fname.str("");
    fname << fpath << "Traces_"<<AddZero(fNumber)<<fNumber<<".dat";
    ofstream outf(fname.str().c_str());


    // Check if there are events at all
    if(!event.HasREvent())
    {
      WARNING("RdChannelNoiseASCIIExporter::No radio event found!");
      return eContinueLoop;
    } else {
      REvent& rEvent = event.GetREvent();
      // loop through stations and for every station through every channel
      for (REvent::StationIterator sIt = rEvent.StationsBegin();
           sIt != rEvent.StationsEnd(); ++sIt) {
        Station& station = *sIt;
        for (Station::ChannelIterator cIt = station.ChannelsBegin();
             cIt != station.ChannelsEnd(); ++cIt) {
          Channel& channel = *cIt;
          outf << station.GetId() << " " << channel.GetId();
          
          const revt::ChannelTimeSeries& timeSeries =
            channel.GetConstChannelTimeSeries();
          outf << " " << timeSeries.GetBinning()/nanosecond;
          for (unsigned int i = 0; i < timeSeries.GetSize(); ++i) 
            outf << " " << timeSeries[i]; 
          outf << endl;
        }
      }
    }
    outf.close();
    
    --fNumberOfTracestoPrepare;
    if (fNumberOfTracestoPrepare<=0) { 
      INFO("We've done enough for today"); 
      return eBreakLoop;
      }
    return eSuccess;
  }


  VModule::ResultFlag
  RdChannelNoiseASCIIExporter::Finish()
  {
    // Put any termination or cleanup code here.
    // This method is called once at the end of the run.

    INFO("RdChannelNoiseASCIIExporter::Finish()");

    return eSuccess;
  }

}