DQMFileSaver.cc File Reference

#include "DQMFileSaver.h"
#include "DQMServices/Components/interface/fillJson.h"
#include "DQMServices/Core/interface/DQMStore.h"
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/Framework/interface/Run.h"
#include "FWCore/Framework/interface/LuminosityBlock.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/Version/interface/GetReleaseVersion.h"
#include "FWCore/ServiceRegistry/interface/Service.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/MessageLogger/interface/JobReport.h"
#include "EventFilter/Utilities/interface/EvFDaqDirector.h"
#include "EventFilter/Utilities/interface/FastMonitoringService.h"
#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>
#include <iostream>
#include <vector>
#include <string>
#include <fstream>
#include <utility>
#include <TString.h>
#include <TSystem.h>
#include <boost/property_tree/json_parser.hpp>
#include <boost/property_tree/ptree.hpp>
#include <boost/filesystem.hpp>
#include <boost/format.hpp>

Go to the source code of this file.

Functions
static std::string	dataFileExtension (DQMFileSaver::FileFormat fileFormat)
static void	doSaveForOnline (DQMFileSaver::DQMStore *store, int run, bool enableMultiThread, const std::string &filename, const std::string &directory, const std::string &rxpat, const std::string &rewrite, DQMFileSaver::DQMStore::SaveReferenceTag saveref, int saveRefQMin, const std::string &filterName, DQMFileSaver::FileFormat fileFormat)
static void	getAnInt (const edm::ParameterSet &ps, int &value, const std::string &name)
static std::string	onlineOfflineFileName (const std::string &fileBaseName, const std::string &suffix, const std::string &workflow, const std::string &child, DQMFileSaver::FileFormat fileFormat)

Function Documentation

static std::string dataFileExtension ( DQMFileSaver::FileFormat  fileFormat )

static

Definition at line 44 of file DQMFileSaver.cc.

References edmStreamStallGrapher::extension, DQMFileSaver::PB, DQMFileSaver::ROOT, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by onlineOfflineFileName(), and DQMFileSaver::saveForFilterUnit().

                                                                      {
  std::string extension;
  if (fileFormat == DQMFileSaver::ROOT)
    extension = ".root";
  else if (fileFormat == DQMFileSaver::PB)
    extension = ".pb";
  return extension;
}

static void doSaveForOnline ( DQMFileSaver::DQMStore *  store, int  run, bool  enableMultiThread, const std::string &  filename, const std::string &  directory, const std::string &  rxpat, const std::string &  rewrite, DQMFileSaver::DQMStore::SaveReferenceTag  saveref, int  saveRefQMin, const std::string &  filterName, DQMFileSaver::FileFormat  fileFormat  )

static

Definition at line 152 of file DQMFileSaver.cc.

References DQMFileSaver::PB, DQMFileSaver::ROOT, dqm::dqmstoreimpl::DQMStore::save(), and dqm::dqmstoreimpl::DQMStore::savePB().

Referenced by DQMFileSaver::saveForOnline(), and DQMFileSaver::saveForOnlinePB().

                                                               {
  // TODO(rovere): fix the online case. so far we simply rely on the
  // fact that we assume we will not run multithreaded in online.
  if (fileFormat == DQMFileSaver::ROOT)
    store->save(filename, directory, rxpat, rewrite, enableMultiThread ? run : 0, 0, saveref, saveRefQMin);
  else if (fileFormat == DQMFileSaver::PB)
    store->savePB(filename, filterName, enableMultiThread ? run : 0);
}

static void getAnInt ( const edm::ParameterSet &  ps, int &  value, const std::string &  name  )

static

Definition at line 37 of file DQMFileSaver.cc.

References Exception, edm::ParameterSet::getUntrackedParameter(), Skims_PA_cff::name, and relativeConstraints::value.

Referenced by DQMFileSaver::DQMFileSaver().

                                                                                   {
  value = ps.getUntrackedParameter<int>(name, value);
  if (value < 1 && value != -1)
    throw cms::Exception("DQMFileSaver") << "Invalid '" << name << "' parameter '" << value
                                         << "'.  Must be -1 or >= 1.";
}

static std::string onlineOfflineFileName ( const std::string &  fileBaseName, const std::string &  suffix, const std::string &  workflow, const std::string &  child, DQMFileSaver::FileFormat  fileFormat  )

static

Definition at line 53 of file DQMFileSaver.cc.

References dataFileExtension(), corrVsCorr::filename, AlCaHLTBitMon_QueryRunRegistry::string, and AlCaHarvesting_cff::workflow.

Referenced by DQMFileSaver::saveForOffline(), DQMFileSaver::saveForOfflinePB(), and DQMFileSaver::saveForOnlinePB().

                                                                            {
  size_t pos = 0;
  std::string wflow;
  wflow.reserve(workflow.size() + 3);
  wflow = workflow;
  while ((pos = wflow.find('/', pos)) != std::string::npos)
    wflow.replace(pos++, 1, "__");

  std::string filename = fileBaseName + suffix + wflow + child + dataFileExtension(fileFormat);
  return filename;
}