CMS 3D CMS Logo
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
List of all members | Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes | Static 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 handler (int s)
 
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 ()
 

Static Public Member Functions

static void staticHandler (int s)
 

Private Member Functions

bool closefd ()
 
void finishFileWrite (int ls)
 
void writeJsds ()
 

Private Attributes

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

Static Private Attributes

static RawEventFileWriterForBU * instance = 0
 

Detailed Description

Definition at line 21 of file RawEventFileWriterForBU.h.

Constructor & Destructor Documentation

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

Definition at line 26 of file RawEventFileWriterForBU.cc.

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

26  :
27  // default to .5ms sleep per event
28  microSleep_(ps.getUntrackedParameter<int>("microSleep", 0))
29  //debug_(ps.getUntrackedParameter<bool>("debug", False))
30 {
31 
32  //per-file JSD and FastMonitor
33  rawJsonDef_.setDefaultGroup("legend");
34  rawJsonDef_.addLegendItem("NEvents","integer",DataPointDefinition::SUM);
35 
36  perFileEventCount_.setName("NEvents");
37  perFileSize_.setName("NBytes");
38 
39  fileMon_ = new FastMonitor(&rawJsonDef_,false);
40  fileMon_->registerGlobalMonitorable(&perFileEventCount_,false,nullptr);
41  fileMon_->registerGlobalMonitorable(&perFileSize_,false,nullptr);
42  fileMon_->commit(nullptr);
43 
44  //per-lumi JSD and FastMonitor
45  eolJsonDef_.setDefaultGroup("legend");
46  eolJsonDef_.addLegendItem("NEvents","integer",DataPointDefinition::SUM);
47  eolJsonDef_.addLegendItem("NFiles","integer",DataPointDefinition::SUM);
48  eolJsonDef_.addLegendItem("TotalEvents","integer",DataPointDefinition::SUM);
49  eolJsonDef_.addLegendItem("NLostEvents","integer",DataPointDefinition::SUM);
50 
51  perLumiEventCount_.setName("NEvents");
52  perLumiFileCount_.setName("NFiles");
53  perLumiTotalEventCount_.setName("TotalEvents");
54  perLumiLostEventCount_.setName("NLostEvents");
55  perLumiSize_.setName("NBytes");
56 
57  lumiMon_ = new FastMonitor(&eolJsonDef_,false);
58  lumiMon_->registerGlobalMonitorable(&perLumiEventCount_,false,nullptr);
59  lumiMon_->registerGlobalMonitorable(&perLumiFileCount_,false,nullptr);
60  lumiMon_->registerGlobalMonitorable(&perLumiTotalEventCount_,false,nullptr);
61  lumiMon_->registerGlobalMonitorable(&perLumiLostEventCount_,false,nullptr);
62  lumiMon_->registerGlobalMonitorable(&perLumiSize_,false,nullptr);
63  lumiMon_->commit(nullptr);
64 
65 
66  //per-run JSD and FastMonitor
67  eorJsonDef_.setDefaultGroup("legend");
68  eorJsonDef_.addLegendItem("NEvents","integer",DataPointDefinition::SUM);
69  eorJsonDef_.addLegendItem("NFiles","integer",DataPointDefinition::SUM);
70  eorJsonDef_.addLegendItem("NLumis","integer",DataPointDefinition::SUM);
71  eorJsonDef_.addLegendItem("LastLumi","integer",DataPointDefinition::SUM);
72 
73  perRunEventCount_.setName("NEvents");
74  perRunFileCount_.setName("NFiles");
75  perRunLumiCount_.setName("NLumis");
76  perRunLastLumi_.setName("LastLumi");
77 
78  runMon_ = new FastMonitor(&eorJsonDef_,false);
79  runMon_->registerGlobalMonitorable(&perRunEventCount_,false,nullptr);
80  runMon_->registerGlobalMonitorable(&perRunFileCount_,false,nullptr);
81  runMon_->registerGlobalMonitorable(&perRunLumiCount_,false,nullptr);
82  runMon_->registerGlobalMonitorable(&perRunLastLumi_,false,nullptr);
83  runMon_->commit(nullptr);
84 
85  instance = this;
86 
87  // SIGINT Handler
88  struct sigaction sigIntHandler;
89  sigIntHandler.sa_handler = RawEventFileWriterForBU::staticHandler;
90  sigemptyset(&sigIntHandler.sa_mask);
91  sigIntHandler.sa_flags = 0;
92  sigaction(SIGINT, &sigIntHandler, NULL);
93 
94 }
jsoncollector::DataPointDefinition::addLegendItem
void addLegendItem(std::string const &name, std::string const &type, std::string const &operation)
Definition: DataPointDefinition.cc:91
RawEventFileWriterForBU::rawJsonDef_
DataPointDefinition rawJsonDef_
Definition: RawEventFileWriterForBU.h:74
NULL
#define NULL
Definition: scimark2.h:8
jsoncollector::FastMonitor::registerGlobalMonitorable
void registerGlobalMonitorable(JsonMonitorable *newMonitorable, bool NAifZeroUpdates, unsigned int *nBins=nullptr)
Definition: FastMonitor.cc:62
RawEventFileWriterForBU::eorJsonDef_
DataPointDefinition eorJsonDef_
Definition: RawEventFileWriterForBU.h:76
jsoncollector::JsonMonitorable::setName
virtual void setName(std::string name)
Definition: JsonMonitorable.h:40
RawEventFileWriterForBU::staticHandler
static void staticHandler(int s)
Definition: RawEventFileWriterForBU.h:44
jsoncollector::FastMonitor::commit
void commit(std::vector< unsigned int > *streamLumisPtr)
Definition: FastMonitor.cc:109
SUM
#define SUM(A, B)
Definition: Simplify_begin.h:52
RawEventFileWriterForBU::instance
static RawEventFileWriterForBU * instance
Definition: RawEventFileWriterForBU.h:88
jsoncollector::DataPointDefinition::setDefaultGroup
void setDefaultGroup(std::string const &group)
Definition: DataPointDefinition.h:53
RawEventFileWriterForBU::eolJsonDef_
DataPointDefinition eolJsonDef_
Definition: RawEventFileWriterForBU.h:75
RawEventFileWriterForBU::RawEventFileWriterForBU ( std::string const &  fileName)
explicit

Definition at line 96 of file RawEventFileWriterForBU.cc.

97 {
98 
99 }
RawEventFileWriterForBU::~RawEventFileWriterForBU ( )

Definition at line 101 of file RawEventFileWriterForBU.cc.

References fileMon_, lumiMon_, and runMon_.

102 {
103  delete fileMon_;
104  delete lumiMon_;
105  delete runMon_;
106 }

Member Function Documentation

uint32 RawEventFileWriterForBU::adler32 ( ) const
inline

Definition at line 34 of file RawEventFileWriterForBU.h.

34 { return (adlerb_ << 16) | adlera_; }
bool RawEventFileWriterForBU::closefd ( )
inlineprivate

Definition at line 48 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and initialize().

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

Definition at line 108 of file RawEventFileWriterForBU.cc.

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

109 {
110  ssize_t retval = write(outfd_,(void*)msg.startAddress(), msg.size());
111 
112  if((unsigned)retval!= msg.size()){
113  throw cms::Exception("RawEventFileWriterForBU", "doOutputEvent")
114  << "Error writing FED Raw Data event data to "
115  << fileName_ << ". Possibly the output disk "
116  << "is full?" << std::endl;
117  }
118 
119  // throttle event output
120  usleep(microSleep_);
121  perFileEventCount_.value()++;
122  perFileSize_.value()+=msg.size();
123 
124  // cms::Adler32((const char*) msg.startAddress(), msg.size(), adlera_, adlerb_);
125 }
visualization-live-secondInstance_cfg.msg
string msg
Definition: visualization-live-secondInstance_cfg.py:15
void RawEventFileWriterForBU::doOutputEvent ( boost::shared_array< unsigned char > &  msg)
inline

Definition at line 30 of file RawEventFileWriterForBU.h.

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

Definition at line 127 of file RawEventFileWriterForBU.cc.

References edm::hlt::Exception.

128 {
129 
130  throw cms::Exception("RawEventFileWriterForBU", "doOutputEventFragment")
131  << "Unsupported output mode ";
132 
133  //cms::Adler32((const char*) dataPtr, dataSize, adlera_, adlerb_);
134 }
void RawEventFileWriterForBU::endOfLS ( int  ls)

Definition at line 265 of file RawEventFileWriterForBU.cc.

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

Referenced by handler().

266 {
267  if (closefd()) finishFileWrite(ls);
268  lumiMon_->snap(ls);
269 
270  std::ostringstream ostr;
271 
272  if (run_==-1) makeRunPrefix(destinationDir_);
273 
274  ostr << destinationDir_ << "/"<< runPrefix_ << "_ls" << std::setfill('0') << std::setw(4) << ls << "_EoLS" << ".jsn";
275  //outfd_ = open(ostr.str().c_str(), O_WRONLY | O_CREAT, S_IWUSR | S_IRUSR | S_IWGRP | S_IRGRP | S_IWOTH | S_IROTH);
276  //closefd();
277 
278  std::string path = ostr.str();
279  lumiMon_->outputFullJSON(path, ls);
280  lumiMon_->discardCollected(ls);
281 
282  perRunEventCount_.value() += perLumiEventCount_.value();
283  perRunFileCount_.value() += perLumiFileCount_.value();
284  perRunLumiCount_.value() += 1;
285  perRunLastLumi_.value() = ls;
286 
287  perLumiEventCount_ = 0;
288  perLumiFileCount_ = 0;
289  perLumiTotalEventCount_ = 0;
290  perLumiSize_ = 0;
291  lumiClosed_ = ls;
292 }
jsoncollector::FastMonitor::outputFullJSON
bool outputFullJSON(std::string const &path, unsigned int lumi, bool log=true)
Definition: FastMonitor.cc:249
eostools.ls
def ls
Definition: eostools.py:346
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:255
cmsHarvester.path
tuple path
else: Piece not in the list, fine.
Definition: cmsHarvester.py:1591
jsoncollector::FastMonitor::snap
void snap(unsigned int ls)
Definition: FastMonitor.cc:190
RawEventFileWriterForBU::makeRunPrefix
void makeRunPrefix(std::string const &destinationDir)
Definition: RawEventFileWriterForBU.cc:319
jsoncollector::FastMonitor::discardCollected
void discardCollected(unsigned int forLumi)
Definition: FastMonitor.cc:268
void RawEventFileWriterForBU::finishFileWrite ( int  ls)
private

Definition at line 232 of file RawEventFileWriterForBU.cc.

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

Referenced by endOfLS(), and initialize().

233 {
234 
235  //move raw file from open to run directory
236  rename(fileName_.c_str(),(destinationDir_+fileName_.substr(fileName_.rfind("/"))).c_str());
237 
238  //create equivalent JSON file
239  std::stringstream ss;
240  //TODO:fix this to use DaqDirector convention and better extension replace
241  boost::filesystem::path source(fileName_);
242  std::string path = source.replace_extension(".jsn").string();
243 
244  fileMon_->snap(ls);
245  fileMon_->outputFullJSON(path, ls, false);
246  fileMon_->discardCollected(ls);
247 
248  //move the json file from open
249  rename(path.c_str(),(destinationDir_+path.substr(path.rfind("/"))).c_str());
250  //there is a small chance that script gets interrupted while this isn't consistent (non-atomic)
251  perLumiFileCount_.value()++;
252  perLumiEventCount_.value()+=perFileEventCount_.value();
253  perLumiSize_.value()+=perFileSize_.value();
254  perLumiTotalEventCount_.value()+=perFileEventCount_.value();
255  //update open lumi value when first file is completed
256  lumiOpen_ = ls;
257 
258  edm::LogInfo("RawEventFileWriterForBU") << "Wrote JSON input file: " << path
259  << " with perFileEventCount = " << perFileEventCount_.value()
260  << " and size " << perFileSize_.value();
261 
262 }
jsoncollector::FastMonitor::outputFullJSON
bool outputFullJSON(std::string const &path, unsigned int lumi, bool log=true)
Definition: FastMonitor.cc:249
eostools.ls
def ls
Definition: eostools.py:346
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:255
cmsHarvester.path
tuple path
else: Piece not in the list, fine.
Definition: cmsHarvester.py:1591
jsoncollector::FastMonitor::snap
void snap(unsigned int ls)
Definition: FastMonitor.cc:190
source
static std::string const source
Definition: EdmProvDump.cc:42
jsoncollector::FastMonitor::discardCollected
void discardCollected(unsigned int forLumi)
Definition: FastMonitor.cc:268
void RawEventFileWriterForBU::handler ( int  s)

Definition at line 303 of file RawEventFileWriterForBU.cc.

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

304 {
305  if (lumiOpen_>lumiClosed_) endOfLS(lumiOpen_);
306  printf("Caught signal %d. Writing EOR file!\n",s);
307  if (destinationDir_.size() > 0)
308  {
309  // create EoR file
310  if (run_==-1) makeRunPrefix(destinationDir_);
311  std::string path = destinationDir_ + "/" + runPrefix_ + "_ls0000_EoR.jsn";
312  runMon_->snap(0);
313  runMon_->outputFullJSON(path, 0);
314  }
315  _exit(0);
316 }
jsoncollector::FastMonitor::outputFullJSON
bool outputFullJSON(std::string const &path, unsigned int lumi, bool log=true)
Definition: FastMonitor.cc:249
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:255
cmsHarvester.path
tuple path
else: Piece not in the list, fine.
Definition: cmsHarvester.py:1591
jsoncollector::FastMonitor::snap
void snap(unsigned int ls)
Definition: FastMonitor.cc:190
RawEventFileWriterForBU::makeRunPrefix
void makeRunPrefix(std::string const &destinationDir)
Definition: RawEventFileWriterForBU.cc:319
void RawEventFileWriterForBU::initialize ( std::string const &  destinationDir,
std::string const &  name,
int  ls 
)

Definition at line 136 of file RawEventFileWriterForBU.cc.

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

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

Definition at line 319 of file RawEventFileWriterForBU.cc.

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

Referenced by endOfLS(), and handler().

320 {
321  //dirty hack: extract run number from destination directory
322  std::string::size_type pos = destinationDir.find("run");
323  std::string run = destinationDir.substr(pos+3);
324  run_=atoi(run.c_str());
325  std::stringstream ss;
326  ss << "run" << std::setfill('0') << std::setw(6) << run_;
327  runPrefix_ = ss.str();
328 }
trigger::size_type
uint16_t size_type
Definition: TriggerTypeDefs.h:19
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:255
bool RawEventFileWriterForBU::sharedMode ( ) const
inline

Definition at line 40 of file RawEventFileWriterForBU.h.

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

Definition at line 36 of file RawEventFileWriterForBU.h.

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

36 {}
static void RawEventFileWriterForBU::staticHandler ( int  s)
inlinestatic

Definition at line 44 of file RawEventFileWriterForBU.h.

References instance.

Referenced by RawEventFileWriterForBU().

44 { instance->handler(s); }
RawEventFileWriterForBU::instance
static RawEventFileWriterForBU * instance
Definition: RawEventFileWriterForBU.h:88
void RawEventFileWriterForBU::stop ( )

Definition at line 294 of file RawEventFileWriterForBU.cc.

References destinationDir_, jsoncollector::FastMonitor::outputFullJSON(), cmsHarvester::path, runMon_, runPrefix_, jsoncollector::FastMonitor::snap(), and AlCaHLTBitMon_QueryRunRegistry::string.

295 {
296  // create EoR file
297  std::string path = destinationDir_ + "/" + runPrefix_ + "_ls0000_EoR.jsn";
298  runMon_->snap(0);
299  runMon_->outputFullJSON(path, 0);
300 }
jsoncollector::FastMonitor::outputFullJSON
bool outputFullJSON(std::string const &path, unsigned int lumi, bool log=true)
Definition: FastMonitor.cc:249
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:255
cmsHarvester.path
tuple path
else: Piece not in the list, fine.
Definition: cmsHarvester.py:1591
jsoncollector::FastMonitor::snap
void snap(unsigned int ls)
Definition: FastMonitor.cc:190
void RawEventFileWriterForBU::writeJsds ( )
private

Definition at line 197 of file RawEventFileWriterForBU.cc.

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

Referenced by initialize().

198 {
199 
200  std::stringstream ss;
201  ss << destinationDir_ << "/jsd";
202  mkdir(ss.str().c_str(), S_IRWXU | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH);
203 
204  std::string rawJSDName = ss.str()+"/rawData.jsd";
205  std::string eolJSDName = ss.str()+"/EoLS.jsd";
206  std::string eorJSDName = ss.str()+"/EoR.jsd";
207 
208  fileMon_->setDefPath(rawJSDName);
209  lumiMon_->setDefPath(eolJSDName);
210  runMon_->setDefPath(eorJSDName);
211 
212  struct stat fstat;
213  if (stat (rawJSDName.c_str(), &fstat) != 0) {
214  std::string content;
215  JSONSerializer::serialize(&rawJsonDef_,content);
216  FileIO::writeStringToFile(rawJSDName, content);
217  }
218 
219  if (stat (eolJSDName.c_str(), &fstat) != 0) {
220  std::string content;
221  JSONSerializer::serialize(&eolJsonDef_,content);
222  FileIO::writeStringToFile(eolJSDName, content);
223  }
224 
225  if (stat (eorJSDName.c_str(), &fstat) != 0) {
226  std::string content;
227  JSONSerializer::serialize(&eorJsonDef_,content);
228  FileIO::writeStringToFile(eorJSDName, content);
229  }
230 }
jsoncollector::FastMonitor::setDefPath
void setDefPath(std::string const &dpath)
Definition: FastMonitor.h:30
RawEventFileWriterForBU::rawJsonDef_
DataPointDefinition rawJsonDef_
Definition: RawEventFileWriterForBU.h:74
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:255
RawEventFileWriterForBU::eorJsonDef_
DataPointDefinition eorJsonDef_
Definition: RawEventFileWriterForBU.h:76
ws_sso_content_reader.content
tuple content
Definition: ws_sso_content_reader.py:117
cond::serialize
std::pair< Binary, Binary > serialize(const T &payload, bool packingOnly=false)
Definition: Serialization.h:92
eostools.mkdir
def mkdir
Definition: eostools.py:248
RawEventFileWriterForBU::eolJsonDef_
DataPointDefinition eolJsonDef_
Definition: RawEventFileWriterForBU.h:75

Member Data Documentation

uint32 RawEventFileWriterForBU::adlera_
private

Definition at line 85 of file RawEventFileWriterForBU.h.

Referenced by initialize().

uint32 RawEventFileWriterForBU::adlerb_
private

Definition at line 86 of file RawEventFileWriterForBU.h.

Referenced by initialize().

std::string RawEventFileWriterForBU::destinationDir_
private

Definition at line 81 of file RawEventFileWriterForBU.h.

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

DataPointDefinition RawEventFileWriterForBU::eolJsonDef_
private

Definition at line 75 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU(), and writeJsds().

DataPointDefinition RawEventFileWriterForBU::eorJsonDef_
private

Definition at line 76 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU(), and writeJsds().

FastMonitor* RawEventFileWriterForBU::fileMon_ = nullptr
private

Definition at line 70 of file RawEventFileWriterForBU.h.

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

std::string RawEventFileWriterForBU::fileName_
private

Definition at line 80 of file RawEventFileWriterForBU.h.

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

RawEventFileWriterForBU * RawEventFileWriterForBU::instance = 0
staticprivate

Definition at line 88 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU().

unsigned int RawEventFileWriterForBU::lumiClosed_ = 0
private

Definition at line 91 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and handler().

FastMonitor* RawEventFileWriterForBU::lumiMon_ = nullptr
private

Definition at line 71 of file RawEventFileWriterForBU.h.

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

unsigned int RawEventFileWriterForBU::lumiOpen_ = 0
private

Definition at line 90 of file RawEventFileWriterForBU.h.

Referenced by finishFileWrite(), and handler().

int RawEventFileWriterForBU::microSleep_
private

Definition at line 83 of file RawEventFileWriterForBU.h.

Referenced by doOutputEvent().

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

Definition at line 79 of file RawEventFileWriterForBU.h.

int RawEventFileWriterForBU::outfd_ = -1
private

Definition at line 51 of file RawEventFileWriterForBU.h.

Referenced by doOutputEvent(), and initialize().

IntJ RawEventFileWriterForBU::perFileEventCount_
private

Definition at line 67 of file RawEventFileWriterForBU.h.

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

IntJ RawEventFileWriterForBU::perFileSize_
private

Definition at line 68 of file RawEventFileWriterForBU.h.

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

IntJ RawEventFileWriterForBU::perLumiEventCount_
private

Definition at line 61 of file RawEventFileWriterForBU.h.

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

IntJ RawEventFileWriterForBU::perLumiFileCount_
private

Definition at line 62 of file RawEventFileWriterForBU.h.

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

IntJ RawEventFileWriterForBU::perLumiLostEventCount_
private

Definition at line 64 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU().

IntJ RawEventFileWriterForBU::perLumiSize_
private

Definition at line 65 of file RawEventFileWriterForBU.h.

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

IntJ RawEventFileWriterForBU::perLumiTotalEventCount_
private

Definition at line 63 of file RawEventFileWriterForBU.h.

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

IntJ RawEventFileWriterForBU::perRunEventCount_
private

Definition at line 56 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and RawEventFileWriterForBU().

IntJ RawEventFileWriterForBU::perRunFileCount_
private

Definition at line 57 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and RawEventFileWriterForBU().

IntJ RawEventFileWriterForBU::perRunLastLumi_
private

Definition at line 59 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and RawEventFileWriterForBU().

IntJ RawEventFileWriterForBU::perRunLumiCount_
private

Definition at line 58 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), and RawEventFileWriterForBU().

DataPointDefinition RawEventFileWriterForBU::rawJsonDef_
private

Definition at line 74 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU(), and writeJsds().

int RawEventFileWriterForBU::run_ = -1
private

Definition at line 53 of file RawEventFileWriterForBU.h.

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

FastMonitor* RawEventFileWriterForBU::runMon_ = nullptr
private

Definition at line 72 of file RawEventFileWriterForBU.h.

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

std::string RawEventFileWriterForBU::runPrefix_
private

Definition at line 54 of file RawEventFileWriterForBU.h.

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

bool RawEventFileWriterForBU::writtenJSDs_ =false
private

Definition at line 77 of file RawEventFileWriterForBU.h.

Referenced by initialize().

Generated for CMSSW Reference Manual by doxygen 1.8.5