CMS 3D CMS Logo

List of all members | Public Member Functions | Private Member Functions | Private Attributes
RawEventFileWriterForBU Class Reference

#include <RawEventFileWriterForBU.h>

Public Member Functions

uint32 adler32 () const
 
void doOutputEvent (FRDEventMsgView const &msg)
 
void doOutputEvent (boost::shared_array< unsigned char > &msg)
 
void doOutputEventFragment (unsigned char *dataPtr, unsigned long dataSize)
 
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)
 
bool sharedMode () const
 
void start ()
 
void stop ()
 
 ~RawEventFileWriterForBU ()
 

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::FastMonitorfileMon_ = nullptr
 
std::string fileName_
 
unsigned int lumiClosed_ = 0
 
jsoncollector::FastMonitorlumiMon_ = nullptr
 
unsigned int lumiOpen_ = 0
 
int microSleep_
 
std::auto_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::FastMonitorrunMon_ = nullptr
 
std::string runPrefix_
 
bool writtenJSDs_ =false
 

Detailed Description

Definition at line 19 of file RawEventFileWriterForBU.h.

Constructor & Destructor Documentation

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

Definition at line 25 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.

25  :
26  // default to .5ms sleep per event
27  microSleep_(ps.getUntrackedParameter<int>("microSleep", 0))
28  //debug_(ps.getUntrackedParameter<bool>("debug", False))
29 {
30 
31  //per-file JSD and FastMonitor
32  rawJsonDef_.setDefaultGroup("legend");
34 
35  perFileEventCount_.setName("NEvents");
36  perFileSize_.setName("NBytes");
37 
38  fileMon_ = new FastMonitor(&rawJsonDef_,false);
41  fileMon_->commit(nullptr);
42 
43  //per-lumi JSD and FastMonitor
44  eolJsonDef_.setDefaultGroup("legend");
47  eolJsonDef_.addLegendItem("TotalEvents","integer",DataPointDefinition::SUM);
48  eolJsonDef_.addLegendItem("NLostEvents","integer",DataPointDefinition::SUM);
49 
50  perLumiEventCount_.setName("NEvents");
51  perLumiFileCount_.setName("NFiles");
52  perLumiTotalEventCount_.setName("TotalEvents");
53  perLumiLostEventCount_.setName("NLostEvents");
54  perLumiSize_.setName("NBytes");
55 
56  lumiMon_ = new FastMonitor(&eolJsonDef_,false);
62  lumiMon_->commit(nullptr);
63 
64 
65  //per-run JSD and FastMonitor
66  eorJsonDef_.setDefaultGroup("legend");
71 
72  perRunEventCount_.setName("NEvents");
73  perRunFileCount_.setName("NFiles");
74  perRunLumiCount_.setName("NLumis");
75  perRunLastLumi_.setName("LastLumi");
76 
77  runMon_ = new FastMonitor(&eorJsonDef_,false);
82  runMon_->commit(nullptr);
83 
84 }
void addLegendItem(std::string const &name, std::string const &type, std::string const &operation)
jsoncollector::FastMonitor * fileMon_
jsoncollector::IntJ perLumiLostEventCount_
jsoncollector::IntJ perFileEventCount_
jsoncollector::DataPointDefinition eolJsonDef_
jsoncollector::IntJ perRunLumiCount_
jsoncollector::IntJ perRunLastLumi_
jsoncollector::DataPointDefinition eorJsonDef_
jsoncollector::IntJ perLumiFileCount_
jsoncollector::IntJ perRunEventCount_
void registerGlobalMonitorable(JsonMonitorable *newMonitorable, bool NAifZeroUpdates, unsigned int *nBins=nullptr)
Definition: FastMonitor.cc:63
jsoncollector::IntJ perLumiEventCount_
virtual void setName(std::string name)
jsoncollector::IntJ perLumiSize_
jsoncollector::FastMonitor * runMon_
jsoncollector::IntJ perRunFileCount_
void commit(std::vector< unsigned int > *streamLumisPtr)
Definition: FastMonitor.cc:110
jsoncollector::DataPointDefinition rawJsonDef_
#define SUM(A, B)
jsoncollector::IntJ perLumiTotalEventCount_
jsoncollector::IntJ perFileSize_
void setDefaultGroup(std::string const &group)
jsoncollector::FastMonitor * lumiMon_
RawEventFileWriterForBU::RawEventFileWriterForBU ( std::string const &  fileName)
explicit

Definition at line 86 of file RawEventFileWriterForBU.cc.

87 {
88 
89 }
RawEventFileWriterForBU::~RawEventFileWriterForBU ( )

Definition at line 91 of file RawEventFileWriterForBU.cc.

References fileMon_, lumiMon_, and runMon_.

92 {
93  delete fileMon_;
94  delete lumiMon_;
95  delete runMon_;
96 }
jsoncollector::FastMonitor * fileMon_
jsoncollector::FastMonitor * runMon_
jsoncollector::FastMonitor * lumiMon_

Member Function Documentation

uint32 RawEventFileWriterForBU::adler32 ( ) const
inline

Definition at line 32 of file RawEventFileWriterForBU.h.

References adlera_, and adlerb_.

bool RawEventFileWriterForBU::closefd ( )
inlineprivate

Definition at line 43 of file RawEventFileWriterForBU.h.

References finishFileWrite(), outfd_, and writeJsds().

Referenced by endOfLS(), and initialize().

43 {if(outfd_>=0){close(outfd_); outfd_=-1; return true;} else return false;}
void RawEventFileWriterForBU::doOutputEvent ( FRDEventMsgView const &  msg)

Definition at line 98 of file RawEventFileWriterForBU.cc.

References Exception, fileName_, microSleep_, outfd_, perFileEventCount_, perFileSize_, FRDEventMsgView::size(), FRDEventMsgView::startAddress(), jsoncollector::IntJ::value(), and TriggerAnalyzer::write().

99 {
100  ssize_t retval = write(outfd_,(void*)msg.startAddress(), msg.size());
101 
102  if((unsigned)retval!= msg.size()){
103  throw cms::Exception("RawEventFileWriterForBU", "doOutputEvent")
104  << "Error writing FED Raw Data event data to "
105  << fileName_ << ". Possibly the output disk "
106  << "is full?" << std::endl;
107  }
108 
109  // throttle event output
110  usleep(microSleep_);
112  perFileSize_.value()+=msg.size();
113 
114  // cms::Adler32((const char*) msg.startAddress(), msg.size(), adlera_, adlerb_);
115 }
jsoncollector::IntJ perFileEventCount_
jsoncollector::IntJ perFileSize_
def write(self, setup)
void RawEventFileWriterForBU::doOutputEvent ( boost::shared_array< unsigned char > &  msg)
inline

Definition at line 28 of file RawEventFileWriterForBU.h.

References doOutputEventFragment().

28 {};
void RawEventFileWriterForBU::doOutputEventFragment ( unsigned char *  dataPtr,
unsigned long  dataSize 
)

Definition at line 117 of file RawEventFileWriterForBU.cc.

References Exception.

Referenced by doOutputEvent().

118 {
119 
120  throw cms::Exception("RawEventFileWriterForBU", "doOutputEventFragment")
121  << "Unsupported output mode ";
122 
123  //cms::Adler32((const char*) dataPtr, dataSize, adlera_, adlerb_);
124 }
void RawEventFileWriterForBU::endOfLS ( int  ls)

Definition at line 255 of file RawEventFileWriterForBU.cc.

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

Referenced by start(), and stop().

256 {
257  if (closefd()) finishFileWrite(ls);
258  lumiMon_->snap(ls);
259 
260  std::ostringstream ostr;
261 
263 
264  ostr << destinationDir_ << "/"<< runPrefix_ << "_ls" << std::setfill('0') << std::setw(4) << ls << "_EoLS" << ".jsn";
265  //outfd_ = open(ostr.str().c_str(), O_WRONLY | O_CREAT, S_IWUSR | S_IRUSR | S_IWGRP | S_IRGRP | S_IWOTH | S_IROTH);
266  //closefd();
267 
268  std::string path = ostr.str();
269  lumiMon_->outputFullJSON(path, ls);
271 
274  perRunLumiCount_.value() += 1;
276 
277  perLumiEventCount_ = 0;
278  perLumiFileCount_ = 0;
280  perLumiSize_ = 0;
281  lumiClosed_ = ls;
282 }
jsoncollector::IntJ perRunLumiCount_
jsoncollector::IntJ perRunLastLumi_
jsoncollector::IntJ perLumiFileCount_
jsoncollector::IntJ perRunEventCount_
jsoncollector::IntJ perLumiEventCount_
jsoncollector::IntJ perLumiSize_
jsoncollector::IntJ perRunFileCount_
def ls(path, rec=False)
Definition: eostools.py:348
jsoncollector::IntJ perLumiTotalEventCount_
void snap(unsigned int ls)
Definition: FastMonitor.cc:191
void makeRunPrefix(std::string const &destinationDir)
jsoncollector::FastMonitor * lumiMon_
void discardCollected(unsigned int forLumi)
Definition: FastMonitor.cc:290
bool outputFullJSON(std::string const &path, unsigned int lumi)
Definition: FastMonitor.cc:273
void RawEventFileWriterForBU::finishFileWrite ( int  ls)
private

Definition at line 222 of file RawEventFileWriterForBU.cc.

References destinationDir_, jsoncollector::FastMonitor::discardCollected(), fileMon_, fileName_, eostools::ls(), lumiOpen_, jsoncollector::FastMonitor::outputFullJSON(), callgraph::path, perFileEventCount_, perFileSize_, perLumiEventCount_, perLumiFileCount_, perLumiSize_, perLumiTotalEventCount_, jsoncollector::FastMonitor::snap(), source, AlCaHLTBitMon_QueryRunRegistry::string, and jsoncollector::IntJ::value().

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

223 {
224 
225  //move raw file from open to run directory
226  rename(fileName_.c_str(),(destinationDir_+fileName_.substr(fileName_.rfind("/"))).c_str());
227 
228  //create equivalent JSON file
229  std::stringstream ss;
230  //TODO:fix this to use DaqDirector convention and better extension replace
232  std::string path = source.replace_extension(".jsn").string();
233 
234  fileMon_->snap(ls);
235  fileMon_->outputFullJSON(path, ls);
237 
238  //move the json file from open
239  rename(path.c_str(),(destinationDir_+path.substr(path.rfind("/"))).c_str());
240  //there is a small chance that script gets interrupted while this isn't consistent (non-atomic)
245  //update open lumi value when first file is completed
246  lumiOpen_ = ls;
247 
248  edm::LogInfo("RawEventFileWriterForBU") << "Wrote JSON input file: " << path
249  << " with perFileEventCount = " << perFileEventCount_.value()
250  << " and size " << perFileSize_.value();
251 
252 }
jsoncollector::FastMonitor * fileMon_
Definition: rename.py:1
jsoncollector::IntJ perFileEventCount_
jsoncollector::IntJ perLumiFileCount_
jsoncollector::IntJ perLumiEventCount_
jsoncollector::IntJ perLumiSize_
def ls(path, rec=False)
Definition: eostools.py:348
jsoncollector::IntJ perLumiTotalEventCount_
void snap(unsigned int ls)
Definition: FastMonitor.cc:191
jsoncollector::IntJ perFileSize_
static std::string const source
Definition: EdmProvDump.cc:43
void discardCollected(unsigned int forLumi)
Definition: FastMonitor.cc:290
bool outputFullJSON(std::string const &path, unsigned int lumi)
Definition: FastMonitor.cc:273
void RawEventFileWriterForBU::initialize ( std::string const &  destinationDir,
std::string const &  name,
int  ls 
)

Definition at line 126 of file RawEventFileWriterForBU.cc.

References adlera_, adlerb_, closefd(), destinationDir_, Exception, fileName_, finishFileWrite(), dataset::name, outfd_, perFileEventCount_, perFileSize_, jsoncollector::IntJ::value(), writeJsds(), and writtenJSDs_.

Referenced by start().

127 {
128  destinationDir_ = destinationDir;
129 
130  if (closefd()) finishFileWrite(ls);
131 
132  fileName_ = name;
133 
134  if (!writtenJSDs_) {
135  writeJsds();
136 /* std::stringstream ss;
137  ss << destinationDir_ << "/jsd";
138  mkdir(ss.str().c_str(), S_IRWXU | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH);
139 
140  std::string rawJSDName = ss.str()+"/rawData.jsd";
141  std::string eolJSDName = ss.str()+"/EoLS.jsd";
142  std::string eorJSDName = ss.str()+"/EoR.jsd";
143 
144  fileMon_->setDefPath(rawJSDName);
145  lumiMon_->setDefPath(eolJSDName);
146  runMon_->setDefPath(eorJSDName);
147 
148  struct stat fstat;
149  if (stat (rawJSDName.c_str(), &fstat) != 0) {
150  std::string content;
151  JSONSerializer::serialize(&rawJsonDef_,content);
152  FileIO::writeStringToFile(rawJSDName, content);
153  }
154 
155  if (stat (eolJSDName.c_str(), &fstat) != 0) {
156  std::string content;
157  JSONSerializer::serialize(&eolJsonDef_,content);
158  FileIO::writeStringToFile(eolJSDName, content);
159  }
160 
161  if (stat (eorJSDName.c_str(), &fstat) != 0) {
162  std::string content;
163  JSONSerializer::serialize(&eorJsonDef_,content);
164  FileIO::writeStringToFile(eorJSDName, content);
165  }
166 */
167  writtenJSDs_=true;
168 
169  }
170 
171  outfd_ = open(fileName_.c_str(), O_WRONLY | O_CREAT, S_IRWXU | S_IRWXG | S_IRWXO);
172  edm::LogInfo("RawEventFileWriterForBU") << " opened " << fileName_;
173  if(outfd_ < 0) { //attention here... it may happen that outfd_ is *not* set (e.g. missing initialize call...)
174  throw cms::Exception("RawEventFileWriterForBU","initialize")
175  << "Error opening FED Raw Data event output file: " << name
176  << ": " << strerror(errno) << "\n";
177  }
178 
180  perFileSize_.value() = 0;
181 
182 
183  adlera_ = 1;
184  adlerb_ = 0;
185 }
jsoncollector::IntJ perFileEventCount_
def ls(path, rec=False)
Definition: eostools.py:348
jsoncollector::IntJ perFileSize_
void RawEventFileWriterForBU::makeRunPrefix ( std::string const &  destinationDir)

Definition at line 299 of file RawEventFileWriterForBU.cc.

References findQualityFiles::run, run_, runPrefix_, and AlCaHLTBitMon_QueryRunRegistry::string.

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

300 {
301  //dirty hack: extract run number from destination directory
302  std::string::size_type pos = destinationDir.find("run");
303  std::string run = destinationDir.substr(pos+3);
304  run_=atoi(run.c_str());
305  std::stringstream ss;
306  ss << "run" << std::setfill('0') << std::setw(6) << run_;
307  runPrefix_ = ss.str();
308 }
uint16_t size_type
bool RawEventFileWriterForBU::sharedMode ( ) const
inline

Definition at line 38 of file RawEventFileWriterForBU.h.

References makeRunPrefix(), and AlCaHLTBitMon_QueryRunRegistry::string.

38 {return false;}
void RawEventFileWriterForBU::start ( void  )
inline
void RawEventFileWriterForBU::stop ( )

Definition at line 284 of file RawEventFileWriterForBU.cc.

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

Referenced by start().

285 {
287  edm::LogInfo("RawEventFileWriterForBU") << "Writing EOR file!";
288  if (destinationDir_.size() > 0)
289  {
290  // create EoR file
292  std::string path = destinationDir_ + "/" + runPrefix_ + "_ls0000_EoR.jsn";
293  runMon_->snap(0);
294  runMon_->outputFullJSON(path, 0);
295  }
296 }
jsoncollector::FastMonitor * runMon_
void snap(unsigned int ls)
Definition: FastMonitor.cc:191
void makeRunPrefix(std::string const &destinationDir)
bool outputFullJSON(std::string const &path, unsigned int lumi)
Definition: FastMonitor.cc:273
void RawEventFileWriterForBU::writeJsds ( )
private

Definition at line 187 of file RawEventFileWriterForBU.cc.

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

Referenced by closefd(), and initialize().

188 {
189 
190  std::stringstream ss;
191  ss << destinationDir_ << "/jsd";
192  mkdir(ss.str().c_str(), S_IRWXU | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH);
193 
194  std::string rawJSDName = ss.str()+"/rawData.jsd";
195  std::string eolJSDName = ss.str()+"/EoLS.jsd";
196  std::string eorJSDName = ss.str()+"/EoR.jsd";
197 
198  fileMon_->setDefPath(rawJSDName);
199  lumiMon_->setDefPath(eolJSDName);
200  runMon_->setDefPath(eorJSDName);
201 
202  struct stat fstat;
203  if (stat (rawJSDName.c_str(), &fstat) != 0) {
206  FileIO::writeStringToFile(rawJSDName, content);
207  }
208 
209  if (stat (eolJSDName.c_str(), &fstat) != 0) {
212  FileIO::writeStringToFile(eolJSDName, content);
213  }
214 
215  if (stat (eorJSDName.c_str(), &fstat) != 0) {
218  FileIO::writeStringToFile(eorJSDName, content);
219  }
220 }
jsoncollector::FastMonitor * fileMon_
void setDefPath(std::string const &dpath)
Definition: FastMonitor.h:30
std::pair< Binary, Binary > serialize(const T &payload)
Definition: Serialization.h:62
jsoncollector::DataPointDefinition eolJsonDef_
jsoncollector::DataPointDefinition eorJsonDef_
jsoncollector::FastMonitor * runMon_
jsoncollector::DataPointDefinition rawJsonDef_
def mkdir(path)
Definition: eostools.py:250
jsoncollector::FastMonitor * lumiMon_

Member Data Documentation

uint32 RawEventFileWriterForBU::adlera_
private

Definition at line 81 of file RawEventFileWriterForBU.h.

Referenced by adler32(), and initialize().

uint32 RawEventFileWriterForBU::adlerb_
private

Definition at line 82 of file RawEventFileWriterForBU.h.

Referenced by adler32(), and initialize().

std::string RawEventFileWriterForBU::destinationDir_
private

Definition at line 77 of file RawEventFileWriterForBU.h.

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

jsoncollector::DataPointDefinition RawEventFileWriterForBU::eolJsonDef_
private

Definition at line 71 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU(), and writeJsds().

jsoncollector::DataPointDefinition RawEventFileWriterForBU::eorJsonDef_
private

Definition at line 72 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU(), and writeJsds().

jsoncollector::FastMonitor* RawEventFileWriterForBU::fileMon_ = nullptr
private
std::string RawEventFileWriterForBU::fileName_
private

Definition at line 76 of file RawEventFileWriterForBU.h.

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

unsigned int RawEventFileWriterForBU::lumiClosed_ = 0
private

Definition at line 85 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and stop().

jsoncollector::FastMonitor* RawEventFileWriterForBU::lumiMon_ = nullptr
private
unsigned int RawEventFileWriterForBU::lumiOpen_ = 0
private

Definition at line 84 of file RawEventFileWriterForBU.h.

Referenced by finishFileWrite(), and stop().

int RawEventFileWriterForBU::microSleep_
private

Definition at line 79 of file RawEventFileWriterForBU.h.

Referenced by doOutputEvent().

std::auto_ptr<std::ofstream> RawEventFileWriterForBU::ost_
private

Definition at line 75 of file RawEventFileWriterForBU.h.

int RawEventFileWriterForBU::outfd_ = -1
private

Definition at line 46 of file RawEventFileWriterForBU.h.

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

jsoncollector::IntJ RawEventFileWriterForBU::perFileEventCount_
private
jsoncollector::IntJ RawEventFileWriterForBU::perFileSize_
private
jsoncollector::IntJ RawEventFileWriterForBU::perLumiEventCount_
private

Definition at line 56 of file RawEventFileWriterForBU.h.

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

jsoncollector::IntJ RawEventFileWriterForBU::perLumiFileCount_
private

Definition at line 57 of file RawEventFileWriterForBU.h.

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

jsoncollector::IntJ RawEventFileWriterForBU::perLumiLostEventCount_
private

Definition at line 59 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU().

jsoncollector::IntJ RawEventFileWriterForBU::perLumiSize_
private

Definition at line 60 of file RawEventFileWriterForBU.h.

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

jsoncollector::IntJ RawEventFileWriterForBU::perLumiTotalEventCount_
private

Definition at line 58 of file RawEventFileWriterForBU.h.

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

jsoncollector::IntJ RawEventFileWriterForBU::perRunEventCount_
private

Definition at line 51 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and RawEventFileWriterForBU().

jsoncollector::IntJ RawEventFileWriterForBU::perRunFileCount_
private

Definition at line 52 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and RawEventFileWriterForBU().

jsoncollector::IntJ RawEventFileWriterForBU::perRunLastLumi_
private

Definition at line 54 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and RawEventFileWriterForBU().

jsoncollector::IntJ RawEventFileWriterForBU::perRunLumiCount_
private

Definition at line 53 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and RawEventFileWriterForBU().

jsoncollector::DataPointDefinition RawEventFileWriterForBU::rawJsonDef_
private

Definition at line 70 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU(), and writeJsds().

int RawEventFileWriterForBU::run_ = -1
private

Definition at line 48 of file RawEventFileWriterForBU.h.

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

jsoncollector::FastMonitor* RawEventFileWriterForBU::runMon_ = nullptr
private
std::string RawEventFileWriterForBU::runPrefix_
private

Definition at line 49 of file RawEventFileWriterForBU.h.

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

bool RawEventFileWriterForBU::writtenJSDs_ =false
private

Definition at line 73 of file RawEventFileWriterForBU.h.

Referenced by initialize().