RawEventFileWriterForBU Class Reference

#include <RawEventFileWriterForBU.h>

Public Member Functions
uint32	adler32 () const
void	doOutputEvent (FRDEventMsgView const &msg)
void	endOfLS (int ls)
void	initialize (std::string const &destinationDir, std::string const &name, int ls)
void	makeRunPrefix (std::string const &destinationDir)
	RawEventFileWriterForBU (edm::ParameterSet const &ps)
	RawEventFileWriterForBU (std::string const &fileName)
void	start ()
void	stop ()
	~RawEventFileWriterForBU ()

Static Public Member Functions
static void	extendDescription (edm::ParameterSetDescription &desc)

Private Member Functions
bool	closefd ()
void	finishFileWrite (int ls)
void	writeJsds ()

Private Attributes
uint32	adlera_
uint32	adlerb_
std::string	destinationDir_
jsoncollector::DataPointDefinition	eolJsonDef_
jsoncollector::DataPointDefinition	eorJsonDef_
jsoncollector::FastMonitor *	fileMon_ = nullptr
std::string	fileName_
unsigned int	frdFileVersion_
unsigned int	lumiClosed_ = 0
jsoncollector::FastMonitor *	lumiMon_ = nullptr
unsigned int	lumiOpen_ = 0
int	microSleep_
std::unique_ptr< std::ofstream >	ost_
int	outfd_ = -1
jsoncollector::IntJ	perFileEventCount_
jsoncollector::IntJ	perFileSize_
jsoncollector::IntJ	perLumiEventCount_
jsoncollector::IntJ	perLumiFileCount_
jsoncollector::IntJ	perLumiLostEventCount_
jsoncollector::IntJ	perLumiSize_
jsoncollector::IntJ	perLumiTotalEventCount_
jsoncollector::IntJ	perRunEventCount_
jsoncollector::IntJ	perRunFileCount_
jsoncollector::IntJ	perRunLastLumi_
jsoncollector::IntJ	perRunLumiCount_
jsoncollector::DataPointDefinition	rawJsonDef_
int	run_ = -1
jsoncollector::FastMonitor *	runMon_ = nullptr
std::string	runPrefix_
bool	writtenJSDs_ = false

Detailed Description

Definition at line 21 of file RawEventFileWriterForBU.h.

Constructor & Destructor Documentation

RawEventFileWriterForBU() [1/2]

RawEventFileWriterForBU::RawEventFileWriterForBU ( edm::ParameterSet const &  ps )

explicit

Definition at line 23 of file RawEventFileWriterForBU.cc.

References jsoncollector::DataPointDefinition::addLegendItem(), jsoncollector::FastMonitor::commit(), eolJsonDef_, eorJsonDef_, fileMon_, lumiMon_, perFileEventCount_, perFileSize_, perLumiEventCount_, perLumiFileCount_, perLumiLostEventCount_, perLumiSize_, perLumiTotalEventCount_, perRunEventCount_, perRunFileCount_, perRunLastLumi_, perRunLumiCount_, rawJsonDef_, jsoncollector::FastMonitor::registerGlobalMonitorable(), runMon_, jsoncollector::DataPointDefinition::setDefaultGroup(), jsoncollector::JsonMonitorable::setName(), and SUM.

    : microSleep_(ps.getParameter<int>("microSleep")),
      frdFileVersion_(ps.getParameter<unsigned int>("frdFileVersion")) {
  //per-file JSD and FastMonitor
  rawJsonDef_.setDefaultGroup("legend");
  rawJsonDef_.addLegendItem("NEvents", "integer", DataPointDefinition::SUM);

  perFileEventCount_.setName("NEvents");
  perFileSize_.setName("NBytes");

  fileMon_ = new FastMonitor(&rawJsonDef_, false);
  fileMon_->registerGlobalMonitorable(&perFileEventCount_, false, nullptr);
  fileMon_->registerGlobalMonitorable(&perFileSize_, false, nullptr);
  fileMon_->commit(nullptr);

  //per-lumi JSD and FastMonitor
  eolJsonDef_.setDefaultGroup("legend");
  eolJsonDef_.addLegendItem("NEvents", "integer", DataPointDefinition::SUM);
  eolJsonDef_.addLegendItem("NFiles", "integer", DataPointDefinition::SUM);
  eolJsonDef_.addLegendItem("TotalEvents", "integer", DataPointDefinition::SUM);
  eolJsonDef_.addLegendItem("NLostEvents", "integer", DataPointDefinition::SUM);

  perLumiEventCount_.setName("NEvents");
  perLumiFileCount_.setName("NFiles");
  perLumiTotalEventCount_.setName("TotalEvents");
  perLumiLostEventCount_.setName("NLostEvents");
  perLumiSize_.setName("NBytes");

  lumiMon_ = new FastMonitor(&eolJsonDef_, false);
  lumiMon_->registerGlobalMonitorable(&perLumiEventCount_, false, nullptr);
  lumiMon_->registerGlobalMonitorable(&perLumiFileCount_, false, nullptr);
  lumiMon_->registerGlobalMonitorable(&perLumiTotalEventCount_, false, nullptr);
  lumiMon_->registerGlobalMonitorable(&perLumiLostEventCount_, false, nullptr);
  lumiMon_->registerGlobalMonitorable(&perLumiSize_, false, nullptr);
  lumiMon_->commit(nullptr);

  //per-run JSD and FastMonitor
  eorJsonDef_.setDefaultGroup("legend");
  eorJsonDef_.addLegendItem("NEvents", "integer", DataPointDefinition::SUM);
  eorJsonDef_.addLegendItem("NFiles", "integer", DataPointDefinition::SUM);
  eorJsonDef_.addLegendItem("NLumis", "integer", DataPointDefinition::SUM);
  eorJsonDef_.addLegendItem("LastLumi", "integer", DataPointDefinition::SUM);

  perRunEventCount_.setName("NEvents");
  perRunFileCount_.setName("NFiles");
  perRunLumiCount_.setName("NLumis");
  perRunLastLumi_.setName("LastLumi");

  runMon_ = new FastMonitor(&eorJsonDef_, false);
  runMon_->registerGlobalMonitorable(&perRunEventCount_, false, nullptr);
  runMon_->registerGlobalMonitorable(&perRunFileCount_, false, nullptr);
  runMon_->registerGlobalMonitorable(&perRunLumiCount_, false, nullptr);
  runMon_->registerGlobalMonitorable(&perRunLastLumi_, false, nullptr);
  runMon_->commit(nullptr);
}

RawEventFileWriterForBU() [2/2]

RawEventFileWriterForBU::RawEventFileWriterForBU ( std::string const &  fileName )

explicit

Definition at line 79 of file RawEventFileWriterForBU.cc.

{}

~RawEventFileWriterForBU()

RawEventFileWriterForBU::~RawEventFileWriterForBU

(

)

Definition at line 81 of file RawEventFileWriterForBU.cc.

References fileMon_, lumiMon_, and runMon_.

                                                  {
  delete fileMon_;
  delete lumiMon_;
  delete runMon_;
}

Member Function Documentation

adler32()

uint32 RawEventFileWriterForBU::adler32 ( ) const

inline

Definition at line 29 of file RawEventFileWriterForBU.h.

References adlera_, and adlerb_.

{ return (adlerb_ << 16) | adlera_; }

closefd()

bool RawEventFileWriterForBU::closefd ( )

inlineprivate

Definition at line 40 of file RawEventFileWriterForBU.h.

References outfd_.

Referenced by endOfLS(), finishFileWrite(), and initialize().

                 {
    if (outfd_ >= 0) {
      close(outfd_);
      outfd_ = -1;
      return true;
    } else
      return false;
  }

doOutputEvent()

void RawEventFileWriterForBU::doOutputEvent

(

FRDEventMsgView const &

msg

)

Definition at line 87 of file RawEventFileWriterForBU.cc.

References Exception, fileName_, microSleep_, mps_check::msg, outfd_, perFileEventCount_, perFileSize_, jsoncollector::IntJ::value(), and writeEcalDQMStatus::write.

                                                                      {
  ssize_t retval = write(outfd_, (void*)msg.startAddress(), msg.size());

  if ((unsigned)retval != msg.size()) {
    throw cms::Exception("RawEventFileWriterForBU", "doOutputEvent")
        << "Error writing FED Raw Data event data to " << fileName_ << ".  Possibly the output disk "
        << "is full?" << std::endl;
  }

  // throttle event output
  usleep(microSleep_);
  perFileEventCount_.value()++;
  perFileSize_.value() += msg.size();

  //  cms::Adler32((const char*) msg.startAddress(), msg.size(), adlera_, adlerb_);
}

endOfLS()

void RawEventFileWriterForBU::endOfLS

(

int

ls

)

Definition at line 262 of file RawEventFileWriterForBU.cc.

References closefd(), destinationDir_, jsoncollector::FastMonitor::discardCollected(), finishFileWrite(), eostools::ls(), lumiClosed_, lumiMon_, makeRunPrefix(), outfd_, jsoncollector::FastMonitor::outputFullJSON(), castor_dqm_sourceclient_file_cfg::path, perLumiEventCount_, perLumiFileCount_, perLumiSize_, perLumiTotalEventCount_, perRunEventCount_, perRunFileCount_, perRunLastLumi_, perRunLumiCount_, run_, runPrefix_, jsoncollector::FastMonitor::snap(), AlCaHLTBitMon_QueryRunRegistry::string, and jsoncollector::IntJ::value().

Referenced by stop().

                                            {
  if (outfd_ != -1) {
    finishFileWrite(ls);
    closefd();
  }
  lumiMon_->snap(ls);

  std::ostringstream ostr;

  if (run_ == -1)
    makeRunPrefix(destinationDir_);

  ostr << destinationDir_ << "/" << runPrefix_ << "_ls" << std::setfill('0') << std::setw(4) << ls << "_EoLS"
       << ".jsn";
  //outfd_ = open(ostr.str().c_str(), O_WRONLY | O_CREAT,  S_IWUSR | S_IRUSR | S_IWGRP | S_IRGRP | S_IWOTH | S_IROTH);
  //closefd();

  std::string path = ostr.str();
  lumiMon_->outputFullJSON(path, ls);
  lumiMon_->discardCollected(ls);

  perRunEventCount_.value() += perLumiEventCount_.value();
  perRunFileCount_.value() += perLumiFileCount_.value();
  perRunLumiCount_.value() += 1;
  perRunLastLumi_.value() = ls;

  perLumiEventCount_ = 0;
  perLumiFileCount_ = 0;
  perLumiTotalEventCount_ = 0;
  perLumiSize_ = 0;
  lumiClosed_ = ls;
}

extendDescription()

void RawEventFileWriterForBU::extendDescription ( edm::ParameterSetDescription &  desc )

static

Definition at line 320 of file RawEventFileWriterForBU.cc.

References submitPVResolutionJobs::desc.

                                                                                {
  desc.add<int>("microSleep", 0);
  desc.add<unsigned int>("frdFileVersion", 0);
}

finishFileWrite()

void RawEventFileWriterForBU::finishFileWrite ( int  ls )

private

Definition at line 210 of file RawEventFileWriterForBU.cc.

References closefd(), destinationDir_, jsoncollector::FastMonitor::discardCollected(), fileMon_, fileName_, frdFileVersion_, eostools::ls(), lumiOpen_, outfd_, jsoncollector::FastMonitor::outputFullJSON(), castor_dqm_sourceclient_file_cfg::path, perFileEventCount_, perFileSize_, perLumiEventCount_, perLumiFileCount_, perLumiSize_, perLumiTotalEventCount_, run_, jsoncollector::FastMonitor::snap(), source, AlCaHLTBitMon_QueryRunRegistry::string, jsoncollector::IntJ::value(), and writeEcalDQMStatus::write.

Referenced by endOfLS(), and initialize().

                                                    {
  if (frdFileVersion_ == 1) {
    //rewind
    lseek(outfd_, 0, SEEK_SET);
    FRDFileHeader_v1 frdFileHeader(perFileEventCount_.value(), (uint32_t)ls, perFileSize_.value());
    write(outfd_, (char*)&frdFileHeader, sizeof(FRDFileHeader_v1));
    closefd();
    //move raw file from open to run directory
    rename(fileName_.c_str(), (destinationDir_ + fileName_.substr(fileName_.rfind('/'))).c_str());

    edm::LogInfo("RawEventFileWriterForBU")
        << "Wrote RAW input file: " << fileName_ << " with perFileEventCount = " << perFileEventCount_.value()
        << " and size " << perFileSize_.value();
  } else if (frdFileVersion_ == 2) {
    lseek(outfd_, 0, SEEK_SET);
    FRDFileHeader_v2 frdFileHeader(0, perFileEventCount_.value(), (uint32_t)run_, (uint32_t)ls, perFileSize_.value());
    write(outfd_, (char*)&frdFileHeader, sizeof(FRDFileHeader_v2));
    closefd();
    //move raw file from open to run directory
    rename(fileName_.c_str(), (destinationDir_ + fileName_.substr(fileName_.rfind('/'))).c_str());
    edm::LogInfo("RawEventFileWriterForBU")
        << "Wrote RAW input file: " << fileName_ << " with perFileEventCount = " << perFileEventCount_.value()
        << " and size " << perFileSize_.value();
  } else {
    closefd();
    //move raw file from open to run directory
    rename(fileName_.c_str(), (destinationDir_ + fileName_.substr(fileName_.rfind('/'))).c_str());
    //create equivalent JSON file
    //TODO:fix this to use DaqDirector convention and better extension replace
    std::filesystem::path source(fileName_);
    std::string path = source.replace_extension(".jsn").string();

    fileMon_->snap(ls);
    fileMon_->outputFullJSON(path, ls);
    fileMon_->discardCollected(ls);

    //move the json file from open
    rename(path.c_str(), (destinationDir_ + path.substr(path.rfind('/'))).c_str());

    edm::LogInfo("RawEventFileWriterForBU")
        << "Wrote JSON input file: " << path << " with perFileEventCount = " << perFileEventCount_.value()
        << " and size " << perFileSize_.value();
  }
  //there is a small chance that script gets interrupted while this isn't consistent (non-atomic)
  perLumiFileCount_.value()++;
  perLumiEventCount_.value() += perFileEventCount_.value();
  perLumiSize_.value() += perFileSize_.value();
  perLumiTotalEventCount_.value() += perFileEventCount_.value();
  //update open lumi value when first file is completed
  lumiOpen_ = ls;
}

initialize()

void RawEventFileWriterForBU::initialize	(	std::string const &	destinationDir,
		std::string const &	name,
		int	ls
	)

Definition at line 104 of file RawEventFileWriterForBU.cc.

References adlera_, adlerb_, cms::cuda::assert(), closefd(), destinationDir_, Exception, fileName_, finishFileWrite(), frdFileVersion_, eostools::ls(), Skims_PA_cff::name, outfd_, perFileEventCount_, perFileSize_, jsoncollector::IntJ::value(), writeJsds(), and writtenJSDs_.

                                                                                                       {
  destinationDir_ = destinationDir;

  if (outfd_ != -1) {
    finishFileWrite(ls);
    closefd();
  }

  fileName_ = name;

  if (!writtenJSDs_) {
    writeJsds();
    /*    std::stringstream ss;
    ss << destinationDir_ << "/jsd";
    mkdir(ss.str().c_str(), S_IRWXU | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH);

    std::string rawJSDName = ss.str()+"/rawData.jsd";
    std::string eolJSDName = ss.str()+"/EoLS.jsd";
    std::string eorJSDName = ss.str()+"/EoR.jsd";

    fileMon_->setDefPath(rawJSDName);
    lumiMon_->setDefPath(eolJSDName);
    runMon_->setDefPath(eorJSDName);

    struct stat   fstat;
    if (stat (rawJSDName.c_str(), &fstat) != 0) {
      std::string content;
      JSONSerializer::serialize(&rawJsonDef_,content);
      FileIO::writeStringToFile(rawJSDName, content);
    }

    if (stat (eolJSDName.c_str(), &fstat) != 0) {
      std::string content;
      JSONSerializer::serialize(&eolJsonDef_,content);
      FileIO::writeStringToFile(eolJSDName, content);
    }

    if (stat (eorJSDName.c_str(), &fstat) != 0) {
      std::string content;
      JSONSerializer::serialize(&eorJsonDef_,content);
      FileIO::writeStringToFile(eorJSDName, content);
    }
*/
    writtenJSDs_ = true;
  }

  outfd_ = open(fileName_.c_str(), O_WRONLY | O_CREAT, S_IRWXU | S_IRWXG | S_IRWXO);
  edm::LogInfo("RawEventFileWriterForBU") << " opened " << fileName_;

  if (outfd_ < 0) {  //attention here... it may happen that outfd_ is *not* set (e.g. missing initialize call...)
    throw cms::Exception("RawEventFileWriterForBU", "initialize")
        << "Error opening FED Raw Data event output file: " << name << ": " << strerror(errno) << "\n";
  }

  perFileEventCount_.value() = 0;
  perFileSize_.value() = 0;

  adlera_ = 1;
  adlerb_ = 0;

  if (frdFileVersion_ == 1) {
    //reserve space for file header
    ftruncate(outfd_, sizeof(FRDFileHeader_v1));
    lseek(outfd_, sizeof(FRDFileHeader_v1), SEEK_SET);
    perFileSize_.value() = sizeof(FRDFileHeader_v1);
  } else if (frdFileVersion_ == 2) {
    ftruncate(outfd_, sizeof(FRDFileHeader_v2));
    lseek(outfd_, sizeof(FRDFileHeader_v2), SEEK_SET);
    perFileSize_.value() = sizeof(FRDFileHeader_v2);
  }
  assert(frdFileVersion_ <= 2);
}

makeRunPrefix()

void RawEventFileWriterForBU::makeRunPrefix

(

std::string const &

destinationDir

)

Definition at line 310 of file RawEventFileWriterForBU.cc.

References writedatasetfile::run, run_, runPrefix_, contentValuesCheck::ss, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by endOfLS(), and stop().

                                                                           {
  //dirty hack: extract run number from destination directory
  std::string::size_type pos = destinationDir.rfind("/run");
  std::string run = destinationDir.substr(pos + 4);
  run_ = atoi(run.c_str());
  std::stringstream ss;
  ss << "run" << std::setfill('0') << std::setw(6) << run_;
  runPrefix_ = ss.str();
}

start()

void RawEventFileWriterForBU::start ( )

inline

Definition at line 31 of file RawEventFileWriterForBU.h.

Referenced by progressbar.ProgressBar::__next__(), Types.LuminosityBlockRange::cppID(), and Types.EventRange::cppID().

{}

stop()

void RawEventFileWriterForBU::stop

(

)

Definition at line 295 of file RawEventFileWriterForBU.cc.

References destinationDir_, endOfLS(), lumiClosed_, lumiOpen_, makeRunPrefix(), jsoncollector::FastMonitor::outputFullJSON(), castor_dqm_sourceclient_file_cfg::path, run_, runMon_, runPrefix_, jsoncollector::FastMonitor::snap(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                   {
  if (lumiOpen_ > lumiClosed_)
    endOfLS(lumiOpen_);
  edm::LogInfo("RawEventFileWriterForBU") << "Writing EOR file!";
  if (!destinationDir_.empty()) {
    // create EoR file
    if (run_ == -1)
      makeRunPrefix(destinationDir_);
    std::string path = destinationDir_ + "/" + runPrefix_ + "_ls0000_EoR.jsn";
    runMon_->snap(0);
    runMon_->outputFullJSON(path, 0);
  }
}

writeJsds()

void RawEventFileWriterForBU::writeJsds ( )

private

Definition at line 177 of file RawEventFileWriterForBU.cc.

References Skims_PA_cff::content, destinationDir_, eolJsonDef_, eorJsonDef_, fileMon_, lumiMon_, eostools::mkdir(), rawJsonDef_, runMon_, cond::serialize(), jsoncollector::FastMonitor::setDefPath(), contentValuesCheck::ss, edm_modernize_messagelogger::stat, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by initialize().

                                        {
  std::stringstream ss;
  ss << destinationDir_ << "/jsd";
  mkdir(ss.str().c_str(), S_IRWXU | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH);

  std::string rawJSDName = ss.str() + "/rawData.jsd";
  std::string eolJSDName = ss.str() + "/EoLS.jsd";
  std::string eorJSDName = ss.str() + "/EoR.jsd";

  fileMon_->setDefPath(rawJSDName);
  lumiMon_->setDefPath(eolJSDName);
  runMon_->setDefPath(eorJSDName);

  struct stat fstat;
  if (stat(rawJSDName.c_str(), &fstat) != 0) {
    std::string content;
    JSONSerializer::serialize(&rawJsonDef_, content);
    FileIO::writeStringToFile(rawJSDName, content);
  }

  if (stat(eolJSDName.c_str(), &fstat) != 0) {
    std::string content;
    JSONSerializer::serialize(&eolJsonDef_, content);
    FileIO::writeStringToFile(eolJSDName, content);
  }

  if (stat(eorJSDName.c_str(), &fstat) != 0) {
    std::string content;
    JSONSerializer::serialize(&eorJsonDef_, content);
    FileIO::writeStringToFile(eorJSDName, content);
  }
}

Member Data Documentation

adlera_

uint32 RawEventFileWriterForBU::adlera_

private

Definition at line 85 of file RawEventFileWriterForBU.h.

Referenced by adler32(), and initialize().

adlerb_

uint32 RawEventFileWriterForBU::adlerb_

private

Definition at line 86 of file RawEventFileWriterForBU.h.

Referenced by adler32(), and initialize().

destinationDir_

std::string RawEventFileWriterForBU::destinationDir_

private

Definition at line 80 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), finishFileWrite(), initialize(), stop(), and writeJsds().

eolJsonDef_

jsoncollector::DataPointDefinition RawEventFileWriterForBU::eolJsonDef_

private

Definition at line 74 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU(), and writeJsds().

eorJsonDef_

jsoncollector::DataPointDefinition RawEventFileWriterForBU::eorJsonDef_

private

Definition at line 75 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU(), and writeJsds().

fileMon_

jsoncollector::FastMonitor* RawEventFileWriterForBU::fileMon_ = nullptr

private

Definition at line 69 of file RawEventFileWriterForBU.h.

Referenced by finishFileWrite(), RawEventFileWriterForBU(), writeJsds(), and ~RawEventFileWriterForBU().

fileName_

std::string RawEventFileWriterForBU::fileName_

private

Definition at line 79 of file RawEventFileWriterForBU.h.

Referenced by doOutputEvent(), finishFileWrite(), and initialize().

frdFileVersion_

unsigned int RawEventFileWriterForBU::frdFileVersion_

private

Definition at line 83 of file RawEventFileWriterForBU.h.

Referenced by finishFileWrite(), and initialize().

lumiClosed_

unsigned int RawEventFileWriterForBU::lumiClosed_ = 0

private

Definition at line 89 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and stop().

lumiMon_

jsoncollector::FastMonitor* RawEventFileWriterForBU::lumiMon_ = nullptr

private

Definition at line 70 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), RawEventFileWriterForBU(), writeJsds(), and ~RawEventFileWriterForBU().

lumiOpen_

unsigned int RawEventFileWriterForBU::lumiOpen_ = 0

private

Definition at line 88 of file RawEventFileWriterForBU.h.

Referenced by finishFileWrite(), and stop().

microSleep_

int RawEventFileWriterForBU::microSleep_

private

Definition at line 82 of file RawEventFileWriterForBU.h.

Referenced by doOutputEvent().

ost_

std::unique_ptr<std::ofstream> RawEventFileWriterForBU::ost_

private

Definition at line 78 of file RawEventFileWriterForBU.h.

outfd_

int RawEventFileWriterForBU::outfd_ = -1

private

Definition at line 50 of file RawEventFileWriterForBU.h.

Referenced by closefd(), doOutputEvent(), endOfLS(), finishFileWrite(), and initialize().

perFileEventCount_

jsoncollector::IntJ RawEventFileWriterForBU::perFileEventCount_

private

Definition at line 66 of file RawEventFileWriterForBU.h.

Referenced by doOutputEvent(), finishFileWrite(), initialize(), and RawEventFileWriterForBU().

perFileSize_

jsoncollector::IntJ RawEventFileWriterForBU::perFileSize_

private

Definition at line 67 of file RawEventFileWriterForBU.h.

Referenced by doOutputEvent(), finishFileWrite(), initialize(), and RawEventFileWriterForBU().

perLumiEventCount_

jsoncollector::IntJ RawEventFileWriterForBU::perLumiEventCount_

private

Definition at line 60 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), finishFileWrite(), and RawEventFileWriterForBU().

perLumiFileCount_

jsoncollector::IntJ RawEventFileWriterForBU::perLumiFileCount_

private

Definition at line 61 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), finishFileWrite(), and RawEventFileWriterForBU().

perLumiLostEventCount_

jsoncollector::IntJ RawEventFileWriterForBU::perLumiLostEventCount_

private

Definition at line 63 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU().

perLumiSize_

jsoncollector::IntJ RawEventFileWriterForBU::perLumiSize_

private

Definition at line 64 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), finishFileWrite(), and RawEventFileWriterForBU().

perLumiTotalEventCount_

jsoncollector::IntJ RawEventFileWriterForBU::perLumiTotalEventCount_

private

Definition at line 62 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), finishFileWrite(), and RawEventFileWriterForBU().

perRunEventCount_

jsoncollector::IntJ RawEventFileWriterForBU::perRunEventCount_

private

Definition at line 55 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and RawEventFileWriterForBU().

perRunFileCount_

jsoncollector::IntJ RawEventFileWriterForBU::perRunFileCount_

private

Definition at line 56 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and RawEventFileWriterForBU().

perRunLastLumi_

jsoncollector::IntJ RawEventFileWriterForBU::perRunLastLumi_

private

Definition at line 58 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and RawEventFileWriterForBU().

perRunLumiCount_

jsoncollector::IntJ RawEventFileWriterForBU::perRunLumiCount_

private

Definition at line 57 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and RawEventFileWriterForBU().

rawJsonDef_

jsoncollector::DataPointDefinition RawEventFileWriterForBU::rawJsonDef_

private

Definition at line 73 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU(), and writeJsds().

run_

int RawEventFileWriterForBU::run_ = -1

private

Definition at line 52 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), finishFileWrite(), makeRunPrefix(), and stop().

runMon_

jsoncollector::FastMonitor* RawEventFileWriterForBU::runMon_ = nullptr

private

Definition at line 71 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU(), stop(), writeJsds(), and ~RawEventFileWriterForBU().

runPrefix_

std::string RawEventFileWriterForBU::runPrefix_

private

Definition at line 53 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), makeRunPrefix(), and stop().

writtenJSDs_

bool RawEventFileWriterForBU::writtenJSDs_ = false

private

Definition at line 76 of file RawEventFileWriterForBU.h.

Referenced by initialize().