JCheckParameters.cc File Reference

Auxiliary program to check trigger parameters in ROOT files against the DB values. More...

#include <string>
#include <iostream>
#include <sstream>
#include "evt/Head.hh"
#include "evt/Evt.hh"
#include "JDAQ/JDAQTimeslice.hh"
#include "JDAQ/JDAQEvent.hh"
#include "JDAQ/JDAQSummaryslice.hh"
#include "JTrigger/JTriggerParameters.hh"
#include "JSupport/JMultipleFileScanner.hh"
#include "JSupport/JFileRecorder.hh"
#include "JSupport/JTriggerParametersSupportkit.hh"
#include "JSupport/JTreeScanner.hh"
#include "JSupport/JSupport.hh"
#include "Jeep/JParser.hh"
#include "Jeep/JMessage.hh"
#include "KM3NeTDBClient.h"
#include "JDB/JDB.hh"
#include "JDB/JSelector.hh"
#include "JDBTriggerParameters.hh"

Go to the source code of this file.

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

Detailed Description

Auxiliary program to check trigger parameters in ROOT files against the DB values.

Author

lnauta

Definition in file JCheckParameters.cc.

Function Documentation

int main	(	int	argc,
		char **	argv
	)

Definition at line 34 of file JCheckParameters.cc.

{
  using namespace std;
  using namespace JPP;
  using namespace KM3NETDB;
  using namespace JDBTRIGGERPARAMETERS;

  JMultipleFileScanner<JDAQTimeslice> inputFile;
  string detid;
  string usr;
  string pwd;
  int debug;

  try {

    JParser<> zap("Auxiliary program to check trigger parameters in ROOT files against the DB value.");

    zap['f'] = make_field(inputFile);
    zap['D'] = make_field(detid)               = "D_ORCA002", "D_ARCA001";
    zap['u'] = make_field(usr);
    zap['!'] = make_field(pwd);
    zap['d'] = make_field(debug)               = 1;

    zap(argc, argv);
  }
  catch(const exception& error) {
    FATAL(error.what() << endl);
  }

  JTriggerParameters parameters;

  try {
    parameters = getTriggerParameters(inputFile);
    NOTICE("Get trigger parameters from input." << endl);
  }
  catch(const JException& error) {
    FATAL("No trigger parameters from input." << endl);
  }

  int runNumber = 0;
  while (inputFile.hasNext()) {
    JDAQTimeslice* timeslice = inputFile.next();
    runNumber = timeslice->getRunNumber();
    break;
  }
  if (runNumber == 0) { 
    FATAL("File does not contain a valid run number. Aborting" << endl);
  }


  // Make streams for DB interaction
  istringstream detector_selector_stream(DETECTOR_SELECTOR + detid);
  JSelector detector_selector;
  detector_selector_stream >> detector_selector; 
  
  string run_setup_id;

  // Connecting to DB
  try {
    // Get run setup information
    JDB::reset(usr, pwd);
    ResultSet& rs = JDB::get()->StreamDS(DB_TABLE_RUNS, detector_selector);

    std::map<string, int> run_column_map;
    for (unsigned int i = 0; i != rs.FieldCount(); ++i) {
      run_column_map[rs.FieldName(i)] = i;
    }
    while (rs.Next()) {
      if (std::stoi(rs.GetString(run_column_map[RUN_TABLE_RUN_COLUMN])) == runNumber) { 
        run_setup_id = rs.GetString(run_column_map[RUN_TABLE_SETUPID_COLUMN]);
      }
    }
    rs.Close();
  }
  catch(const exception& error) {
    FATAL(error.what() << endl);
  }

  stringstream buffer;    
  std::map<string, string> ParameterMap;

  try {
    // Get parameter map 
    istringstream param_selector_stream(DAQ_SELECTOR);
    JSelector param_selector;
    param_selector_stream >> param_selector;

    JDB::reset(usr, pwd);
    ResultSet& rs_allparams = JDB::get()->StreamDS(DB_TABLE_ALL_PARAMETERS, param_selector);

    std::map<string, int> parameter_column_map;
    for (unsigned int i = 0; i != rs_allparams.FieldCount(); ++i) {
      parameter_column_map[rs_allparams.FieldName(i)] = i;
    }
    while (rs_allparams.Next()) {
      if (rs_allparams.GetString(parameter_column_map[ALL_PARAMETERS_TABLE_NAME_COLUMN]).find(DAQ_FILTER_STRING) != std::string::npos) {
        ParameterMap[rs_allparams.GetString(parameter_column_map[ALL_PARAMETERS_TABLE_OID_COLUMN])] = 
          rs_allparams.GetString(parameter_column_map[ALL_PARAMETERS_TABLE_NAME_COLUMN]).erase(0, std::strlen(DAQ_FILTER_STRING));
      }
    }
    rs_allparams.Close();
  }
  catch(const exception& error) {
    FATAL(error.what() << endl);
  }


  try {
    // Get trigger parameter information
    istringstream run_setup_selector_stream(DETECTOR_SELECTOR + detid + SELECTOR_SEPERATOR + RUN_SETUP_OID_SELECTOR + run_setup_id);
    JSelector run_setup_selector;
    run_setup_selector_stream >> run_setup_selector; 

    JDB::reset(usr, pwd);
    ResultSet& rs_params = JDB::get()->StreamDS(DB_TABLE_RUN_SETUP_PARAMETERS, run_setup_selector);

    std::map<string, int> rs_params_column_map;
    for (unsigned int i = 0; i != rs_params.FieldCount(); ++i) {
      rs_params_column_map[rs_params.FieldName(i)] = i;
    }
    while (rs_params.Next()) {
      for(map<string, string>::const_iterator it = ParameterMap.begin(); it != ParameterMap.end(); ++it) {
        if (rs_params.GetString(rs_params_column_map[RUN_SETUP_TABLE_PAR_OID_COLUMN]) == it->first) {
          buffer << it->second << "=" << rs_params.GetString(rs_params_column_map[RUN_SETUP_TABLE_VALUE_COLUMN]) << ";\n";
        }
      }
    }
  }
  catch(const exception& error) {
    FATAL(error.what() << endl);
  }

  cout << buffer.str() << endl;

  JTriggerParameters parameters_from_db;
  buffer >> parameters_from_db;

  bool return_file_is_db;
  return_file_is_db = parameters.equals(parameters_from_db);
  if (return_file_is_db) NOTICE("The parameters for run " << runNumber << "are equivalent" << endl);
  else NOTICE("The parameters for run " << runNumber << " are NOT equivalent." << endl);
  return return_file_is_db;
}