JRoot.cc File Reference

#include <string>
#include <iostream>
#include <fstream>
#include <iomanip>
#include <vector>
#include <limits>
#include <string.h>
#include "TROOT.h"
#include "TFile.h"
#include "JDAQ/JDAQEventIO.hh"
#include "JDAQ/JDAQTimesliceIO.hh"
#include "JDAQ/JDAQSummarysliceIO.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"

Go to the source code of this file.

Namespaces
	JSUPPORT
	Support classes and methods for experiment specific I/O.

Functions
int	main (int argc, char **argv)

Detailed Description

Auxiliary program to convert binary data to ROOT formatted data.

Author

mdejong

Definition in file JRoot.cc.

Function Documentation

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 49 of file JRoot.cc.

{
  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() < (int) getSizeof<JDAQPreamble>()) {
 
        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), getSizeof<JDAQPreamble>());
        
        is.read(buffer.data()        + getSizeof<JDAQPreamble>(), 
                preamble.getLength() - getSizeof<JDAQPreamble>());
        
        JByteArrayReader bin(buffer.data(), buffer.size());
 
        i->second->copy(bin);
 
      } else {
 
        in.ignore((streamsize) (preamble.getLength() - getSizeof<JDAQPreamble>()));
 
        ERROR("Illegal data type, skip" << endl);
      }
    }
    STATUS(endl);
 
    in.close();
  }
 
  writer.close();
}