rawfileCheck.cxx

Go to the documentation of this file.

// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
// All rights not expressly granted are reserved.
//
// This software is distributed under the terms of the GNU General Public
// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
//
// In applying this license CERN does not waive the privileges and immunities
// granted to it by virtue of its status as an Intergovernmental Organization
// or submit itself to any jurisdiction.
 
 
#include "DetectorsRaw/RawFileReader.h"
#include "CommonUtils/ConfigurableParam.h"
#include "Framework/Logger.h"
#include <TStopwatch.h>
#include <boost/program_options.hpp>
#include <iostream>
#include <string>
#include <vector>
 
namespace bpo = boost::program_options;
 
using namespace o2::raw;
 
int main(int argc, char* argv[])
{
  RawFileReader reader;
  std::vector<std::string> fnames;
  std::string config, configKeyValues;
  bpo::variables_map vm;
  bpo::options_description descOpt("Options");
  auto desc_add_option = descOpt.add_options();
  desc_add_option("help,h", "print this help message.");
  desc_add_option("input-conf,c", bpo::value(&config)->default_value(""), "read input from configuration file");
  desc_add_option("max-tf,m", bpo::value<uint32_t>()->default_value(0xffffffff), " ID to read (counts from 0)");
  desc_add_option("verbosity,v", bpo::value<int>()->default_value(reader.getVerbosity()), "1: long report, 2 or 3: print or dump all RDH");
  desc_add_option("spsize,s", bpo::value<int>()->default_value(reader.getNominalSPageSize()), "nominal super-page size in bytes");
  desc_add_option("buffer-size,b", bpo::value<size_t>()->default_value(reader.getNominalSPageSize()), "buffer size for files preprocessing");
  desc_add_option("detect-tf0", "autodetect HBFUtils start Orbit/BC from 1st TF seen");
  desc_add_option("calculate-tf-start", "calculate TF start instead of using TType");
  desc_add_option("rorc", "impose RORC as default detector mode");
  desc_add_option("configKeyValues", bpo::value(&configKeyValues)->default_value(""), "semicolon separated key=value strings");
  for (int i = 0; i < RawFileReader::NErrorsDefined; i++) {
    auto ei = RawFileReader::ErrTypes(i);
    desc_add_option(RawFileReader::nochk_opt(ei).c_str(), RawFileReader::nochk_expl(ei).c_str());
  }
 
  bpo::options_description hiddenOpt("hidden");
  hiddenOpt.add_options()("files", bpo::value(&fnames)->composing(), "");
 
  bpo::options_description fullOpt("cmd");
  fullOpt.add(descOpt).add(hiddenOpt);
 
  bpo::positional_options_description posOpt;
  posOpt.add("files", -1);
 
  auto printHelp = [&](std::ostream& stream) {
    stream << "Usage:   " << argv[0] << " [options] file0 [... fileN]" << std::endl;
    stream << descOpt << std::endl;
    stream << "  (input files are optional if config file was provided)" << std::endl;
  };
 
  try {
    bpo::store(bpo::command_line_parser(argc, argv)
                 .options(fullOpt)
                 .positional(posOpt)
                 .allow_unregistered()
                 .run(),
               vm);
    bpo::notify(vm);
    if (argc == 1 || vm.count("help") || (fnames.empty() && config.empty())) {
      printHelp(std::cout);
      return 0;
    }
    o2::conf::ConfigurableParam::updateFromString(configKeyValues);
  } catch (const bpo::error& e) {
    std::cerr << e.what() << "\n\n";
    std::cerr << "Error parsing command line arguments\n";
    printHelp(std::cerr);
    return -1;
  }
 
  RawFileReader::RDH rdh;
  LOG(info) << "RawDataHeader v" << int(rdh.version) << " is assumed";
 
  RawFileReader::ReadoutCardType rocard = vm.count("rorc") ? o2::raw::RawFileReader::ReadoutCardType::RORC : o2::raw::RawFileReader::ReadoutCardType::CRU;
 
  reader.setVerbosity(vm["verbosity"].as<int>());
  reader.setNominalSPageSize(vm["spsize"].as<int>());
  reader.setMaxTFToRead(vm["max-tf"].as<uint32_t>());
  reader.setBufferSize(vm["buffer-size"].as<size_t>());
  reader.setPreferCalculatedTFStart(vm.count("calculate-tf-start"));
  reader.setDefaultReadoutCardType(rocard);
  reader.setTFAutodetect(vm.count("detect-tf0") ? RawFileReader::FirstTFDetection::Pending : RawFileReader::FirstTFDetection::Disabled);
  uint32_t errmap = 0;
  for (int i = RawFileReader::NErrorsDefined; i--;) {
    auto ei = RawFileReader::ErrTypes(i);
    if (RawFileReader::ErrCheckDefaults[i]) {
      errmap |= 0x1 << i;
    }
    if (vm.count(RawFileReader::nochk_opt(ei).c_str())) { // toggle
      errmap ^= 0x1 << i;
    }
    LOG(info) << ((errmap & (0x1 << i)) ? "apply " : "ignore") << " check for " << RawFileReader::ErrNames[i].data();
  }
 
  if (!config.empty()) {
    auto inp = o2::raw::RawFileReader::parseInput(config);
    reader.loadFromInputsMap(inp);
  }
 
  for (int i = 0; i < fnames.size(); i++) {
    reader.addFile(fnames[i]);
  }
 
  TStopwatch sw;
  sw.Start();
 
  reader.setCheckErrors(errmap);
  reader.init();
 
  sw.Print();
 
  return 0;
}