JRoot.cc

Go to the documentation of this file.

 
#include <string>
#include <iostream>
#include <fstream>
#include <iomanip>
#include <vector>
#include <limits>
#include <string.h>
 
#include "TROOT.h"
#include "TFile.h"
 
#include "JDAQ/JDAQEvent.hh"
#include "JDAQ/JDAQTimeslice.hh"
#include "JDAQ/JDAQSummaryslice.hh"
 
#include "JROOT/JTreeReader.hh"
#include "JIO/JStreamIO.hh"
#include "JIO/JByteArrayIO.hh"
#include "JSupport/JSupport.hh"
#include "JSupport/JAutoTreeWriter.hh"
 
#include "Jeep/JParser.hh"
#include "Jeep/JMessage.hh"
 
 
namespace JSUPPORT {
 
  /**
   * Get key for given DAQ data type.
   *
   * \param  type             data type
   * \return                  map element
   */
  template<>
  template<class T>
  int JAutoTreeWriter<int>::getKey(JLANG::JType<T> type)
  {
    return KM3NETDAQ::getDataType<T>();
  }
}
 
 
/**
 * \file
 * Auxiliary program to convert binary data to ROOT formatted data.
 * \author mdejong
 */
int main(int argc, char **argv)
{
  using namespace std;
 
  vector<string> inputFile;
  string         outputFile;
  Long64_t       numberOfEvents;
  int            debug;
 
  try { 
 
    JParser<> zap("Auxiliary program to convert binary data to ROOT formatted data.");
    
    zap['f'] = make_field(inputFile);
    zap['o'] = make_field(outputFile);
    zap['n'] = make_field(numberOfEvents)  = numeric_limits<Long64_t>::max();
    zap['d'] = make_field(debug)           = 1;
 
    zap(argc, argv);
  }
  catch(const exception &error) {
    FATAL(error.what() << endl);
  }
 
  
  cout.tie(&cerr);
 
  using namespace KM3NETDAQ;
  using namespace JPP;
 
 
  JAutoTreeWriter<int> writer;
 
  writer.open(outputFile.c_str());
 
  if (!writer.is_open())
    FATAL("Error opening file " << outputFile << endl);
 
  writer.insert<JDAQTypes_t>();
 
 
  JDAQPreamble preamble;
  vector<char> buffer;
 
  Long64_t event_count = 0;
  
  for (vector<string>::const_iterator i = inputFile.begin(); i != inputFile.end(); ++i) {
    
    STATUS("File: " << *i << endl);
    
    ifstream in(i->c_str());
    
    for (JStreamReader is(in); event_count < numberOfEvents; ++event_count) {
 
      STATUS("event: " << setw(10) << event_count << '\r'); DEBUG(endl);
 
      if (!(is >> preamble))
        break;
 
      DEBUG("length   " << preamble.getLength()   << endl);
      DEBUG("type     " << preamble.getDataType() << endl);
 
      if (preamble.getLength() < JDAQPreamble::sizeOf()) {
 
        ERROR("File " << *i << " invalid length " << preamble.getLength() << endl);
 
        break;
      }
 
      JAutoTreeWriter<int>::iterator i = writer.find(preamble.getDataType());
 
      if (i != writer.end()) {
 
        buffer.resize(preamble.getLength());
 
        memcpy(buffer.data(), static_cast<JDAQAbstractPreamble*>(&preamble), JDAQPreamble::sizeOf());
        
        is.read(buffer.data()        + JDAQPreamble::sizeOf(), 
                preamble.getLength() - JDAQPreamble::sizeOf());
        
        JByteArrayReader bin(buffer.data(), buffer.size());
 
        i->second->copy(bin);
 
      } else {
 
        in.ignore((streamsize) (preamble.getLength() - JDAQPreamble::sizeOf()));
 
        ERROR("Illegal data type, skip" << endl);
      }
    }
    STATUS(endl);
 
    in.close();
  }
 
  writer.close();
}