DQMFileSaver.cc File Reference

#include "DQMServices/Components/src/DQMFileSaver.h"
#include "DQMServices/Core/interface/DQMStore.h"
#include "DQMServices/Core/interface/MonitorElement.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 (DQMStore *store, int run, bool enableMultiThread, const std::string &filename, const std::string &directory, const std::string &rxpat, const std::string &rewrite, 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 48 of file DQMFileSaver.cc.

References 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 ( DQMStore *  store, int  run, bool  enableMultiThread, const std::string &  filename, const std::string &  directory, const std::string &  rxpat, const std::string &  rewrite, DQMStore::SaveReferenceTag  saveref, int  saveRefQMin, const std::string &  filterName, DQMFileSaver::FileFormat  fileFormat  )

static

Definition at line 160 of file DQMFileSaver.cc.

References DQMFileSaver::PB, and DQMFileSaver::ROOT.

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 38 of file DQMFileSaver.cc.

References Exception, edm::ParameterSet::getUntrackedParameter(), mergeVDriftHistosByStation::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 59 of file DQMFileSaver.cc.

References dataFileExtension(), lut2db_cfg::filename, AlCaHLTBitMon_QueryRunRegistry::string, and reco_calib_source_client_cfg::workflow.

Referenced by DQMFileSaver::endJob(), 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;
}