JsonOutputProducer Class Reference

Classes
struct	JsonConfiguration
struct	JsonConfigurationBlock
struct	JsonEvent
struct	JsonEventState
struct	JsonTriggerEventState
struct	JsonVars

Public Member Functions
JsonEventState	eventState (State _s, int _m, const std::string &_l, const std::string &_t)
	JsonOutputProducer (bool _writeJson, std::string _file_name)
std::string	output_filename_base (int _run) const
JsonEvent &	pushEvent (int _run, int _lumi, int _event)
void	write ()

Public Attributes
JsonConfiguration	configuration
std::map< int, std::vector< JsonEvent > >	m_run_events
std::string	out_filename_base
bool	useSingleOutFile
JsonVars	vars
bool	writeJson

Private Member Functions
unsigned int	labelId (std::string labelName)
unsigned int	typeId (std::string typeName)

Static Private Member Functions
static std::string	indent (size_t _nTabs)
static std::string	key (const std::string &_key, const std::string &_delim="")
static std::string	key_int (const std::string &_key, int _int, const std::string &_delim="")
static std::string	key_string (const std::string &_key, const std::string &_string, const std::string &_delim="")
static std::string	list_string (const std::vector< std::string > &_values, const std::string &_delim="")
static std::string	string (const std::string &_string, const std::string &_delim="")

Static Private Attributes
static size_t	tab_spaces = 0

Detailed Description

Definition at line 420 of file hltDiff.cc.

Constructor & Destructor Documentation

JsonOutputProducer()

JsonOutputProducer::JsonOutputProducer ( bool  _writeJson, std::string  _file_name  )

inline

Definition at line 698 of file hltDiff.cc.

      : writeJson(_writeJson), out_filename_base(std::move(_file_name)) {
    useSingleOutFile = out_filename_base.length() > 0;
  }

Member Function Documentation

eventState()

JsonEventState JsonOutputProducer::eventState ( State  _s, int  _m, const std::string &  _l, const std::string &  _t  )

inline

Definition at line 718 of file hltDiff.cc.

References hgcalDigitizer_cfi::_m.

                                                                                        {
    return JsonEventState(_s, _m, this->labelId(_l), this->typeId(_t));
  }

indent()

static std::string JsonOutputProducer::indent ( size_t  _nTabs )

inlinestaticprivate

Definition at line 425 of file hltDiff.cc.

References str, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by ntuplePrintersDiff.TrackingParticlePrinter::_parentageChain(), ntuplePrintersDiff.SeedPrinter::printHits(), ntuplePrintersDiff.TrackPrinter::printHits(), and ntuplePrintersDiff.TrackingParticlePrinter::printTrackingParticle().

                                         {
    std::string str = "\n";
    while (_nTabs) {
      int nSpaces = tab_spaces;
      while (nSpaces) {
        str.push_back(' ');
        nSpaces--;
      }
      _nTabs--;
    }

    return str;
  }

key()

static std::string JsonOutputProducer::key ( const std::string &  _key, const std::string &  _delim = ""  )

inlinestaticprivate

Definition at line 439 of file hltDiff.cc.

References str, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                            {
    std::string str = "\"\":";
    str.insert(1, _key);
    str.append(_delim);

    return str;
  }

key_int()

static std::string JsonOutputProducer::key_int ( const std::string &  _key, int  _int, const std::string &  _delim = ""  )

inlinestaticprivate

Definition at line 455 of file hltDiff.cc.

References submitPVResolutionJobs::key, str, AlCaHLTBitMon_QueryRunRegistry::string, and to_string().

                                                                                          {
    std::string str = key(_key, _delim);
    str.append(std::to_string(_int));

    return str;
  }

key_string()

static std::string JsonOutputProducer::key_string ( const std::string &  _key, const std::string &  _string, const std::string &  _delim = ""  )

inlinestaticprivate

Definition at line 447 of file hltDiff.cc.

References submitPVResolutionJobs::key, str, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                                             {
    std::string str = key(_key, _delim);
    str.push_back('"');
    str.append(_string);
    str.push_back('"');
    return str;
  }

labelId()

unsigned int JsonOutputProducer::labelId ( std::string  labelName )

inlineprivate

Definition at line 599 of file hltDiff.cc.

References spr::find(), and customiseL1CustomReco::labelName.

                                            {
    unsigned int id = std::find(vars.label.begin(), vars.label.end(), labelName) - vars.label.begin();
    if (id < vars.label.size())
      return id;
    vars.label.push_back(labelName);
    return vars.label.size() - 1;
  }

list_string()

static std::string JsonOutputProducer::list_string ( const std::vector< std::string > &  _values, const std::string &  _delim = ""  )

inlinestaticprivate

Definition at line 470 of file hltDiff.cc.

References ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, str, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                                  {
    std::string str = "[";
    for (auto it = _values.begin(); it != _values.end(); ++it) {
      str.append(_delim);
      str.push_back('"');
      str.append(*it);
      str.push_back('"');
      if (it != --_values.end())
        str.push_back(',');
    }
    str.append(_delim);
    str.push_back(']');

    return str;
  }

output_filename_base()

std::string JsonOutputProducer::output_filename_base ( int  _run ) const

inline

Definition at line 722 of file hltDiff.cc.

References JetHT_cfg::configuration, Skims_PA_cff::name, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                 {
    if (useSingleOutFile)
      return out_filename_base;

    char name[1000];
    sprintf(name,
            "DQM_V0001_R%.9d__OLD_%s__NEW_%s_DQM",
            _run,
            configuration.o.process.c_str(),
            configuration.n.process.c_str());

    return std::string(name);
  }

pushEvent()

JsonEvent& JsonOutputProducer::pushEvent ( int  _run, int  _lumi, int  _event  )

inline

Definition at line 703 of file hltDiff.cc.

References callgrindSwitch_cfi::lastEvent.

                                                        {
    // ensuring that this RUN is present in the producer
    if ((m_run_events.count(_run) == 0 && !useSingleOutFile) || m_run_events.empty())
      m_run_events.emplace(_run, std::vector<JsonEvent>());
    std::vector<JsonEvent>& v_events = useSingleOutFile ? m_run_events.begin()->second : m_run_events.at(_run);
    // check whether the last  event is the one
    if (!v_events.empty()) {
      JsonEvent& lastEvent = v_events.back();
      if (lastEvent.run == _run && lastEvent.lumi == _lumi && lastEvent.event == _event)
        return lastEvent;
    }
    v_events.push_back(JsonEvent(_run, _lumi, _event));
    return v_events.back();
  }

string()

static std::string JsonOutputProducer::string ( const std::string &  _string, const std::string &  _delim = ""  )

inlinestaticprivate

Definition at line 462 of file hltDiff.cc.

References str, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                  {
    std::string str = "\"\"";
    str.insert(1, _string);
    str.append(_delim);

    return str;
  }

typeId()

unsigned int JsonOutputProducer::typeId ( std::string  typeName )

inlineprivate

Definition at line 607 of file hltDiff.cc.

References spr::find(), and dqmiodumpindices::typeName.

                                          {
    unsigned int id = std::find(vars.type.begin(), vars.type.end(), typeName) - vars.type.begin();
    if (id < vars.type.size())
      return id;
    vars.type.push_back(typeName);
    return vars.type.size() - 1;
  }

write()

void JsonOutputProducer::write ( )

inline

Definition at line 736 of file hltDiff.cc.

References JetHT_cfg::configuration, gather_cfg::cout, corrVsCorr::filename, validateAlignments::indent, ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, submitPVResolutionJobs::key, MillePedeFileConverter_cfg::out, DeadROCCounter::out_file, writedatasetfile::run, and AlCaHLTBitMon_QueryRunRegistry::string.

               {
    if (!writeJson)
      return;
    std::set<std::string> filesCreated, filesNotCreated;
    std::ofstream out_file;
    if (!m_run_events.empty()) {
      // Creating a separate file for each run
      for (const auto& runEvents : m_run_events) {
        const int run = runEvents.first;
        const std::vector<JsonEvent>& v_events = runEvents.second;
        // Writing the output to a JSON file
        std::string output_name = output_filename_base(run) += ".json";
        out_file.open(output_name, std::ofstream::out);
        if (out_file.good()) {
          out_file << '{';  // line open
          out_file << configuration.serialise(1) << ',';
          out_file << vars.serialise(1) << ',';
          // writing block for each event
          out_file << indent(1) << key("events") << '[';  // line open
          for (auto it = v_events.begin(); it != v_events.end(); ++it) {
            out_file << (*it).serialise(2);
            if (it != --v_events.end())
              out_file << ',';
          }
          out_file << indent(1) << ']';  // line close
          out_file << indent(0) << "}";  // line close
          out_file.close();
          // Adding file name to the list of created files
          filesCreated.insert(output_name);
        } else
          filesNotCreated.insert(output_name);
      }
    } else {
      // Creating a single file containing with only configuration part
      std::string output_name = output_filename_base(0) += ".json";
      out_file.open(output_name, std::ofstream::out);
      if (out_file.good()) {
        out_file << '{';  // line open
        out_file << configuration.serialise(1) << ',';
        out_file << vars.serialise(1) << ',';
        // writing block for each event
        out_file << indent(1) << key("events") << '[';  // line open
        // for (std::vector<JsonEvent>::const_iterator it = v_events.begin(); it != v_events.end(); ++it) {
        //   out_file << (*it).serialise(2);
        //   if (it != --v_events.end()) out_file << ',';
        // }
        out_file << indent(1) << ']';  // line close
        out_file << indent(0) << "}";  // line close
        out_file.close();
        // Adding file name to the list of created files
        filesCreated.insert(output_name);
      } else
        filesNotCreated.insert(output_name);
    }

    if (!filesCreated.empty()) {
      std::cout << "Created the following JSON files:" << std::endl;
      for (const std::string& filename : filesCreated)
        std::cout << " " << filename << std::endl;
    }

    if (!filesNotCreated.empty()) {
      std::cout << "Failed to create the following JSON files (check output directory and its permissions):"
                << std::endl;
      for (const std::string& filename : filesNotCreated)
        std::cout << " " << filename << std::endl;
    }
  }

Member Data Documentation

configuration

JsonConfiguration JsonOutputProducer::configuration

Definition at line 595 of file hltDiff.cc.

Referenced by showPage.BuildViewer::showResults(), SummaryOutputProducer::writeCSV_module(), and SummaryOutputProducer::writeCSV_trigger().

m_run_events

std::map<int, std::vector<JsonEvent> > JsonOutputProducer::m_run_events

Definition at line 695 of file hltDiff.cc.

out_filename_base

std::string JsonOutputProducer::out_filename_base

Definition at line 488 of file hltDiff.cc.

tab_spaces

size_t JsonOutputProducer::tab_spaces = 0

staticprivate

Definition at line 422 of file hltDiff.cc.

useSingleOutFile

bool JsonOutputProducer::useSingleOutFile

Definition at line 489 of file hltDiff.cc.

vars

JsonVars JsonOutputProducer::vars

Definition at line 596 of file hltDiff.cc.

Referenced by tree.Tree::fill(), tree.Tree::reset(), and tree.Tree::var().

writeJson

bool JsonOutputProducer::writeJson

Definition at line 487 of file hltDiff.cc.