CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
List of all members | Classes | Public Types | Public Member Functions | Private Types | Private Member Functions | Static Private Member Functions | Private Attributes | Static Private Attributes
MatacqProducer Class Reference

#include <MatacqProducer.h>

Inheritance diagram for MatacqProducer:
edm::EDProducer edm::ProducerBase edm::EDConsumerBase edm::ProductRegistryHelper

Classes

struct  MatacqEventId
 
class  PosEstimator
 
struct  stats_t
 

Public Types

enum  calibTrigType_t { laserType = 4, ledType = 5, tpType = 6, pedType = 7 }
 
- Public Types inherited from edm::EDProducer
typedef EDProducer ModuleType
 
typedef WorkerT< EDProducerWorkerType
 
- Public Types inherited from edm::ProducerBase
typedef
ProductRegistryHelper::TypeLabelList 
TypeLabelList
 

Public Member Functions

 MatacqProducer (const edm::ParameterSet &params)
 
virtual void produce (edm::Event &event, const edm::EventSetup &eventSetup)
 
 ~MatacqProducer ()
 
- Public Member Functions inherited from edm::EDProducer
 EDProducer ()
 
virtual ~EDProducer ()
 
- Public Member Functions inherited from edm::ProducerBase
 ProducerBase ()
 
void registerProducts (ProducerBase *, ProductRegistry *, ModuleDescription const &)
 
std::function< void(BranchDescription
const &)> 
registrationCallback () const
 used by the fwk to register list of products More...
 
virtual ~ProducerBase ()
 
- Public Member Functions inherited from edm::EDConsumerBase
 EDConsumerBase ()
 
ProductHolderIndex indexFrom (EDGetToken, BranchType, TypeID const &) const
 
void itemsMayGet (BranchType, std::vector< ProductHolderIndex > &) const
 
void itemsToGet (BranchType, std::vector< ProductHolderIndex > &) const
 
void labelsForToken (EDGetToken iToken, Labels &oLabels) const
 
void updateLookup (BranchType iBranchType, ProductHolderIndexHelper const &)
 
virtual ~EDConsumerBase ()
 

Private Types

typedef FILE * FILE_t
 
typedef off_t filepos_t
 

Private Member Functions

void addMatacqData (edm::Event &event)
 
int getCalibTriggerType (edm::Event &ev) const
 
bool getMatacqEvent (uint32_t runNumber, int32_t orbitId, bool fileChange)
 
bool getMatacqFile (uint32_t runNumber, uint32_t orbitId, bool *fileChange=0)
 
uint32_t getOrbitId (edm::Event &ev) const
 
uint32_t getRunNumber (edm::Event &ev) const
 
void loadOrbitOffset ()
 
bool mcheck (const std::string &name)
 
void mclose ()
 
bool meof ()
 
bool misOpened ()
 
bool mopen (const std::string &name)
 
bool mread (char *buf, size_t n, const char *mess=0, bool peek=false)
 
bool mrewind ()
 
bool mseek (filepos_t offset, int whence=SEEK_SET, const char *mess=0)
 
bool msize (filepos_t &s)
 
bool mtell (filepos_t &pos)
 
void newRun (int prevRun, int newRun)
 

Static Private Member Functions

static std::string runSubDir (uint32_t runNumber)
 

Private Attributes

std::vector< unsigned char > data_
 
std::string digiInstanceName_
 
bool disabled_
 
bool doOrbitOffset_
 
int eventSkipCounter_
 
int fastRetrievalThresh_
 
std::vector< std::string > fileNames_
 
MatacqDataFormatter formatter_
 
bool ignoreTriggerType_
 
FILE_t inFile_
 
std::string inFileName_
 
edm::InputTag inputRawCollection_
 
int32_t lastOrb_
 
std::ofstream logFile_
 
std::string logFileName_
 
bool logTiming_
 
MatacqRawEvent matacq_
 
bool mergeRaw_
 
int onErrorDisablingEvtCnt_
 
uint32_t openedFileRunNumber_
 
std::map< uint32_t, uint32_t > orbitOffset_
 
std::string orbitOffsetFile_
 
PosEstimator posEstim_
 
bool produceDigis_
 
bool produceRaw_
 
std::string rawInstanceName_
 
uint32_t runNumber_
 
timeval startTime_
 
struct MatacqProducer::stats_t stats_
 
std::ofstream timeLog_
 
std::string timeLogFile_
 
timeval timer_
 
bool timing_
 
int verbosity_
 

Static Private Attributes

static const int bufferSize = 30000
 
static const int matacqFedId_ = 655
 
static int orbitTolerance_ = 80
 
static stats_t stats_init = {0,0,0}
 

Additional Inherited Members

- Static Public Member Functions inherited from edm::EDProducer
static const std::string & baseType ()
 
static void fillDescriptions (ConfigurationDescriptions &descriptions)
 
static void prevalidate (ConfigurationDescriptions &descriptions)
 
- Protected Member Functions inherited from edm::EDProducer
CurrentProcessingContext const * currentContext () const
 
- Protected Member Functions inherited from edm::ProducerBase
void callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)
 
- Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > consumes (edm::InputTag const &tag)
 
EDGetToken consumes (const TypeToGet &id, edm::InputTag const &tag)
 
template<BranchType B>
EDGetToken consumes (TypeToGet const &id, edm::InputTag const &tag)
 
ConsumesCollector consumesCollector ()
 Use a ConsumesCollector to gather consumes information from helper functions. More...
 
template<typename ProductType , BranchType B = InEvent>
void consumesMany ()
 
void consumesMany (const TypeToGet &id)
 
template<BranchType B>
void consumesMany (const TypeToGet &id)
 
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > mayConsume (edm::InputTag const &tag)
 
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 
template<BranchType B>
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 

Detailed Description

Definition at line 43 of file MatacqProducer.h.

Member Typedef Documentation

typedef FILE* MatacqProducer::FILE_t
private

Definition at line 58 of file MatacqProducer.h.

typedef off_t MatacqProducer::filepos_t
private

Definition at line 57 of file MatacqProducer.h.

Member Enumeration Documentation

Enumerator
laserType 
ledType 
tpType 
pedType 

Definition at line 46 of file MatacqProducer.h.

Constructor & Destructor Documentation

MatacqProducer::MatacqProducer ( const edm::ParameterSet params)
explicit

Constructor

Parameters
paramsseletive readout parameters

Definition at line 65 of file MatacqProducer.cc.

References gather_cfg::cout, digiInstanceName_, doOrbitOffset_, edm::hlt::Exception, loadOrbitOffset(), logFile_, logFileName_, logTiming_, now(), orbitOffsetFile_, dbtoconf::out, posEstim_, produceDigis_, produceRaw_, rawInstanceName_, startTime_, timeLog_, timeLogFile_, timer_, MatacqProducer::PosEstimator::verbosity(), and verbosity_.

65  :
66  fileNames_(params.getParameter<std::vector<std::string> >("fileNames")),
67  digiInstanceName_(params.getParameter<string>("digiInstanceName")),
68  rawInstanceName_(params.getParameter<string>("rawInstanceName")),
69  timing_(params.getUntrackedParameter<bool>("timing", false)),
70  disabled_(params.getParameter<bool>("disabled")),
71  verbosity_(params.getUntrackedParameter<int>("verbosity", 0)),
72  produceDigis_(params.getParameter<bool>("produceDigis")),
73  produceRaw_(params.getParameter<bool>("produceRaw")),
74  inputRawCollection_(params.getParameter<InputTag>("inputRawCollection")),
75  mergeRaw_(params.getParameter<bool>("mergeRaw")),
76  ignoreTriggerType_(params.getParameter<bool>("ignoreTriggerType")),
77  matacq_(0, 0),
78  inFile_(0),
81  lastOrb_(0),
83  orbitOffsetFile_(params.getUntrackedParameter<std::string>("orbitOffsetFile",
84  "")),
85  inFileName_(""),
87  logFileName_(params.getUntrackedParameter<std::string>("logFileName",
88  "matacqProducer.log")),
90  onErrorDisablingEvtCnt_(params.getParameter<int>("onErrorDisablingEvtCnt")),
91  timeLogFile_(params.getUntrackedParameter<std::string>("timeLogFile", "")),
92  runNumber_(0)
93 {
94  if(verbosity_>=4) cout << "[Matacq " << now() << "] in MatacqProducer ctor" << endl;
95 
96  gettimeofday(&timer_, 0);
97 
98  if(timeLogFile_.size()>0){
99  timeLog_.open(timeLogFile_.c_str());
100  if(timeLog_.fail()){
101  cout << "[LaserSorter " << now() << "] "
102  << "Failed to open file " << timeLogFile_ << " to log timing.\n";
103  logTiming_ = false;
104  } else{
105  logTiming_ = true;
106  }
107  }
108 
110 
111  logFile_.open(logFileName_.c_str(), ios::app | ios::out);
112 
113  if(logFile_.bad()){
114  throw cms::Exception("FileOpen") << "Failed to open file "
115  << logFileName_ << " for logging.\n";
116  }
117 
118  if(produceDigis_){
119  if(verbosity_>0) cout << "[Matacq " << now() << "] registering new "
120  "EcalMatacqDigiCollection product with instance name '"
121  << digiInstanceName_ << "'\n";
122  produces<EcalMatacqDigiCollection>(digiInstanceName_);
123  }
124 
125  if(produceRaw_){
126  if(verbosity_>0) cout << "[Matacq " << now() << "] registering new FEDRawDataCollection "
127  "product with instance name '"
128  << rawInstanceName_ << "'\n";
129  produces<FEDRawDataCollection>(rawInstanceName_);
130  }
131 
132  startTime_.tv_sec = startTime_.tv_usec = 0;
133  if(orbitOffsetFile_.size()>0){
134  doOrbitOffset_ = true;
135  loadOrbitOffset();
136  } else{
137  doOrbitOffset_ = false;
138  }
139  if(verbosity_>=4) cout << "[Matacq " << now() << "] exiting MatacqProducer ctor" << endl;
140 }
std::string inFileName_
T getParameter(std::string const &) const
T getUntrackedParameter(std::string const &, T const &) const
uint32_t runNumber_
std::ofstream logFile_
std::ofstream timeLog_
std::vector< std::string > fileNames_
std::string digiInstanceName_
static stats_t stats_init
struct MatacqProducer::stats_t stats_
edm::InputTag inputRawCollection_
std::string orbitOffsetFile_
tuple out
Definition: dbtoconf.py:99
std::string timeLogFile_
uint32_t openedFileRunNumber_
PosEstimator posEstim_
static const int bufferSize
static std::string now()
MatacqRawEvent matacq_
std::string rawInstanceName_
tuple cout
Definition: gather_cfg.py:121
std::string logFileName_
std::vector< unsigned char > data_
MatacqProducer::~MatacqProducer ( )

Destructor

Definition at line 764 of file MatacqProducer.cc.

References gather_cfg::cout, logTiming_, mclose(), now(), startTime_, and lumiQTWidget::t.

764  {
765  mclose();
766  timeval t;
767  gettimeofday(&t, 0);
768  if(logTiming_ && startTime_.tv_sec!=0){
769  //not using logger, to allow timing with different logging options
770  cout << "[Matacq " << now() << "] Time elapsed between first event and "
771  "destruction of MatacqProducer: "
772  << ((t.tv_sec-startTime_.tv_sec)*1.
773  + (t.tv_usec-startTime_.tv_usec)*1.e-6) << "s\n";
774  }
775 }
static std::string now()
tuple cout
Definition: gather_cfg.py:121

Member Function Documentation

void MatacqProducer::addMatacqData ( edm::Event event)
private

Add matacq digi to the event

Parameters
eventthe event
digiInstanceName_name to give to the matacq digi instance

Definition at line 176 of file MatacqProducer.cc.

References bufferSize, filterCSVwithJSON::copy, gather_cfg::cout, data_, digiInstanceName_, doOrbitOffset_, eventSkipCounter_, formatter_, getCalibTriggerType(), MatacqRawEvent::getDccLen(), getMatacqEvent(), getMatacqFile(), getOrbitId(), MatacqRawEvent::getOrbitId(), MatacqRawEvent::getParsedLen(), getRunNumber(), ignoreTriggerType_, inputRawCollection_, MatacqDataFormatter::interpretRawData(), laserType, matacq_, matacqFedId_, mergeRaw_, MatacqProducer::stats_t::nLaserEventsWithMatacq, MatacqProducer::stats_t::nNonLaserEventsWithMatacq, now(), orbitOffset_, produceDigis_, produceRaw_, rawInstanceName_, convertSQLiteXML::runNumber, stats_, and verbosity_.

Referenced by produce().

176  {
177 
179  event.getByLabel(inputRawCollection_, sourceColl);
180 
181  std::auto_ptr<FEDRawDataCollection> rawColl;
182  if(produceRaw_){
183  if(mergeRaw_){
184  rawColl = auto_ptr<FEDRawDataCollection>(new FEDRawDataCollection(*sourceColl));
185  } else{
186  rawColl = auto_ptr<FEDRawDataCollection>(new FEDRawDataCollection());
187  }
188  }
189 
190  std::auto_ptr<EcalMatacqDigiCollection>
191  digiColl(new EcalMatacqDigiCollection());
192 
193  if(eventSkipCounter_==0){
194  if(sourceColl->FEDData(matacqFedId_).size()>4 && !produceRaw_){
195  //input raw data collection already contains matacqData
196  formatter_.interpretRawData(sourceColl->FEDData(matacqFedId_),
197  *digiColl);
198  } else{
199  bool isLaserEvent = (getCalibTriggerType(event) == laserType);
200 
201 
202  // cout << "---> " << (ignoreTriggerType_?"yes":"no") << " " << getCalibTriggerType(event) << endl;
203 
204  if(isLaserEvent || ignoreTriggerType_){
205 
206  const uint32_t runNumber = getRunNumber(event);
207  const uint32_t orbitId = getOrbitId(event);
208 
209  LogInfo("Matacq") << "Run " << runNumber << "\t Orbit " << orbitId << "\n";
210 
211  bool fileChange;
212  if(doOrbitOffset_){
213  map<uint32_t,uint32_t>::iterator it = orbitOffset_.find(runNumber);
214  if(it == orbitOffset_.end()){
215  LogWarning("Matacq") << "Orbit offset not found for run "
216  << runNumber
217  << ". No orbit correction will be applied.";
218  }
219  }
220 
221  if(getMatacqFile(runNumber, orbitId, &fileChange)){
222  //matacq file retrieval succeeded
223  LogInfo("Matacq") << "Matacq data file found for "
224  << "run " << runNumber << " orbit " << orbitId;
225  if(getMatacqEvent(runNumber, orbitId, fileChange)){
226  if(produceDigis_){
227  formatter_.interpretRawData(matacq_, *digiColl);
228  }
229  if(produceRaw_){
230  uint32_t dataLen64 = matacq_.getParsedLen();
231  if(dataLen64 > bufferSize*8 || matacq_.getDccLen()!= dataLen64){
232  LogWarning("Matacq") << " Error in Matacq event fragment length! "
233  << "DCC len: " << matacq_.getDccLen()
234  << "*8 Bytes, Parsed len: "
235  << matacq_.getParsedLen() << "*8 Bytes. "
236  << "Matacq data will not be included for this event.\n";
237  } else{
238  rawColl->FEDData(matacqFedId_).resize(dataLen64*8);
239  copy(data_.begin(), data_.begin() + dataLen64*8,
240  rawColl->FEDData(matacqFedId_).data());
241  }
242  }
243  LogInfo("Matacq") << "Associating matacq data with orbit id "
244  << matacq_.getOrbitId()
245  << " to dcc event with orbit id "
246  << orbitId << std::endl;
247  if(isLaserEvent){
249  } else{
251  }
252  } else{
253  if(isLaserEvent){
254  LogWarning("Matacq") << "No matacq data found for laser event "
255  << "of run " << runNumber << " orbit "
256  << orbitId;
257  }
258  }
259  } else{
260  LogWarning("Matacq") << "No matacq file found for event "
261  << event.id();
262  }
263  }
264  }
265  if(eventSkipCounter_>0){ //error occured for this events
266  // and some events will be skipped following
267  // to this error.
268  LogInfo("Matacq") << " [" << now() << "] "
270  << " next events will be skipped, following to an "
271  << "error on the last processed event, "
272  << "which is expected to be persistant.";
273  }
274  } else{
276  }
277 
278  if(produceRaw_){
279  if(verbosity_>1) cout << "[Matacq " << now() << "] "
280  << "Adding FEDRawDataCollection collection "
281  << " to event.\n";
282  event.put(rawColl, rawInstanceName_);
283  }
284 
285  if(produceDigis_){
286  if(verbosity_>1) cout << "[Matacq " << now() << "] "
287  << "Adding EcalMatacqDigiCollection collection "
288  << " to event.\n";
289  event.put(digiColl, digiInstanceName_);
290  }
291 }
std::map< uint32_t, uint32_t > orbitOffset_
static const int matacqFedId_
edm::SortedCollection< EcalMatacqDigi > EcalMatacqDigiCollection
static unsigned getOrbitId(unsigned char *data, size_t size)
std::string digiInstanceName_
uint32_t getRunNumber(edm::Event &ev) const
unsigned getDccLen() const
uint32_t getOrbitId(edm::Event &ev) const
struct MatacqProducer::stats_t stats_
edm::InputTag inputRawCollection_
int getCalibTriggerType(edm::Event &ev) const
MatacqDataFormatter formatter_
static const int bufferSize
static std::string now()
MatacqRawEvent matacq_
std::string rawInstanceName_
void interpretRawData(const FEDRawData &data, EcalMatacqDigiCollection &matacqDigiCollection)
tuple cout
Definition: gather_cfg.py:121
std::vector< unsigned char > data_
bool getMatacqFile(uint32_t runNumber, uint32_t orbitId, bool *fileChange=0)
bool getMatacqEvent(uint32_t runNumber, int32_t orbitId, bool fileChange)
int MatacqProducer::getCalibTriggerType ( edm::Event ev) const
private

Definition at line 644 of file MatacqProducer.cc.

References Majority< T >::add(), FEDRawData::data(), data, edm::hlt::Exception, edm::Event::getByLabel(), inputRawCollection_, FEDNumbering::inRange(), edm::HandleBase::isValid(), AlCaHLTBitMon_ParallelJobs::p, lumiPlot::rawdata, Majority< T >::result(), and FEDRawData::size().

Referenced by addMatacqData().

644  {
646  ev.getByLabel(inputRawCollection_, rawdata);
647  if(!(rawdata.isValid())){
648  throw cms::Exception("NotFound")
649  << "No FED raw data collection found. ECAL raw data are "
650  "required to retrieve the trigger type";
651  }
652 
653  Majority<int> stat;
654  for(int id=601; id<=654; ++id){
655  if(!FEDNumbering::inRange(id)) continue;
656  const FEDRawData& data = rawdata->FEDData(id);
657  const int detailedTrigger32 = 5;
658  if(data.size()>=4*(detailedTrigger32+1)){
659  const unsigned char* pTType = data.data() + detailedTrigger32*4;
660  int tType = pTType[1] & 0x7;
661  stat.add(tType);
662  }
663  }
664  double p;
665  int tType = stat.result(&p);
666  if(p<0){
667  //throw cms::Exception("NotFound") << "No ECAL DCC data found\n";
668  LogWarning("NotFound") << "No ECAL DCC data found\n";
669  tType = -1;
670  }
671  if(p<.8){
672  //throw cms::Exception("EventCorruption") << "Inconsitency in detailed trigger type indicated in ECAL DCC data headers\n";
673  LogWarning("EventCorruption") << "Inconsitency in detailed trigger type indicated in ECAL DCC data headers\n";
674  tType = -1;
675  }
676  return tType;
677 }
size_t size() const
Lenght of the data buffer in bytes.
Definition: FEDRawData.h:49
void add(const T &value)
Definition: Majority.h:25
edm::InputTag inputRawCollection_
bool isValid() const
Definition: HandleBase.h:76
bool getByLabel(InputTag const &tag, Handle< PROD > &result) const
Definition: Event.h:361
static bool inRange(int)
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:82
const unsigned char * data() const
Return a const pointer to the beginning of the data buffer.
Definition: FEDRawData.cc:29
dictionary rawdata
Definition: lumiPlot.py:393
T result(double *proba) const
Definition: Majority.h:30
bool MatacqProducer::getMatacqEvent ( uint32_t  runNumber,
int32_t  orbitId,
bool  fileChange 
)
private

Definition at line 340 of file MatacqProducer.cc.

References abs, gather_cfg::cout, data_, MatacqProducer::PosEstimator::eventLength(), edm::hlt::Exception, fastRetrievalThresh_, newFWLiteAna::found, MatacqRawEvent::getDccLen(), MatacqRawEvent::getOrbitId(), MatacqRawEvent::getRunNum(), inFileName_, MatacqProducer::PosEstimator::invalid(), lastOrb_, matacq_, mread(), mrewind(), mseek(), msize(), mtell(), now(), evf::evtn::offset(), orbitTolerance_, pos, MatacqProducer::PosEstimator::pos(), posEstim_, DTTTrigCorrFirst::run, evf::utils::state, and verbosity_.

Referenced by addMatacqData().

342  {
343  filepos_t startPos;
344  if(!mtell(startPos)) return false;
345 
346  int32_t startOrb = -1;
347  const size_t headerSize = 8*8;
348  if(mread((char*)&data_[0], headerSize, "Reading matacq header", true)){
349  startOrb = MatacqRawEvent::getOrbitId(&data_[0], headerSize);
350  if(startOrb<0) startOrb = 0;
351  } else{
352  if(verbosity_>2){
353  cout << "[Matacq " << now() << "] Failed to read matacq header. Moved to start of "
354  " the file.\n";
355  }
356  mrewind();
357  if(mread((char*)&data_[0], headerSize, "Reading matacq header", true)){
358  startPos = 0;
359  startOrb = MatacqRawEvent::getOrbitId(&data_[0], headerSize);
360  } else{
361  if(verbosity_>2) cout << "[Matacq " << now() << "] Looks like matacq file is empty"
362  << "\n";
363  return false;
364  }
365  }
366 
367  if(verbosity_>2) cout << "[Matacq " << now() << "] Last read orbit: " << lastOrb_
368  << " looking for orbit " << orbitId
369  << ". Current file position: " << startPos
370  << " Orbit at current position: " << startOrb << "\n";
371 
372  // f.clear();
373  bool didCoarseMove = false;
374 
375  //FIXME: case where posEtim_.invalid() is false
376  if(!posEstim_.invalid()
377  && (abs(lastOrb_-orbitId) > fastRetrievalThresh_)){
378  filepos_t pos = posEstim_.pos(orbitId);
379 
380  // struct stat st;
381  filepos_t fsize;
382  // if(0==stat(inFileName_.c_str(), &st)){
383  if(msize(fsize)){
384  // const int64_t fsize = st.st_size;
385  if(0!=posEstim_.eventLength() && pos > fsize){
386  //estimated position is beyong end of file
387  //-> move to beginning of last event:
388  int64_t evtSize = posEstim_.eventLength()*sizeof(uint64_t);
389  pos = ((int64_t)fsize/evtSize-1)*evtSize;
390  if(verbosity_>2){
391  cout << "[Matacq " << now() << "] Estimated position was beyond end of file. "
392  "Changed to " << pos << "\n";
393  }
394  }
395  } else{
396  LogWarning("Matacq") << "Failed to access file " << inFileName_ << ".";
397  }
398  if(pos>=0){
399  if(verbosity_>2) cout << "[Matacq " << now() << "] jumping to estimated position "
400  << pos << "\n";
401  mseek(pos, SEEK_SET, "Jumping to estimated event position");
402  if(mread((char*)&data_[0], headerSize, "Reading matacq header", true)){
403  didCoarseMove = true;
404  } else{
405  //estimated position might have been beyond the end of the file,
406  //try, with original position:
407  didCoarseMove = false;
408  if(!mread((char*)&data_[0], headerSize, "Reading event header", true)){
409  return false;
410  }
411  }
412  } else{
413  if(verbosity_) cout << "[Matacq " << now() << "] Event orbit outside of orbit range "
414  "of matacq data file events\n";
415  return false;
416  }
417  }
418 
419  int32_t orb = MatacqRawEvent::getOrbitId(&data_[0], headerSize);
420 
421  if(didCoarseMove){
422  //autoadjustement of threshold for coarse move:
423  if(abs(orb-orbitId) > fastRetrievalThresh_){
424  if(verbosity_>2) cout << "[Matacq " << now() << "] Fast retrieval threshold increased from "
426  fastRetrievalThresh_ = 2*abs(orb-orbitId);
427  if(verbosity_>2) cout << " to " << fastRetrievalThresh_ << "\n";
428  }
429 
430  //if coarse move did not improve situation, rolls back:
431  if(startOrb > 0
432  && (abs(orb-orbitId) > abs(startOrb-orbitId))){
433  if(verbosity_>2) cout << "[Matacq " << now() << "] Estimation (-> orbit " << orb << ") "
434  "was worst than original position (-> orbit "
435  << startOrb
436  << "). Restoring position (" << startPos << ").\n";
437  mseek(startPos, SEEK_SET);
438  mread((char*)&data_[0], headerSize, "Reading event header", true);
439  orb = MatacqRawEvent::getOrbitId(&data_[0], headerSize);
440  }
441  }
442 
443  bool searchBackward = (orb>orbitId)?true:false;
444  //BEWARE: len must be signed, because we are using latter in the code (-len)
445  //expression
446  int len = (int)MatacqRawEvent::getDccLen(&data_[0], headerSize);
447 
448  if(len==0){
449  cout << "[Matacq " << now() << "] read DCC length is null! Cancels matacq event search "
450  << " and move matacq file pointer to beginning of the file. "
451  << "(" << __FILE__ << ":" << __LINE__ << ")."
452  << "\n";
453  //rewind(f);
454  mrewind();
455  return false;
456  }
457 
458  enum state_t { searching, found, failed } state = searching;
459 
460  while(state == searching){
461  orb = MatacqRawEvent::getOrbitId(&data_[0], headerSize);
462  len = (int)MatacqRawEvent::getDccLen(&data_[0], headerSize);
463  uint32_t run = MatacqRawEvent::getRunNum(&data_[0], headerSize);
464  if(verbosity_>3){
465  filepos_t pos = -1;
466  mtell(pos);
467  cout << "[Matacq " << now() << "] Header read at file position "
468  << pos
469  << ": orbit = " << orb
470  << " len = " << len << "x8 Byte"
471  << " run = " << run << "\n";
472  }
473  if((abs(orb-orbitId) < orbitTolerance_)
474  && (runNumber==0 || runNumber==run)){
475  state = found;
476  lastOrb_ = orb;
477  //reads the rest of the event:
478  if((int)data_.size() < len*8){
479  throw cms::Exception("Matacq") << "Buffer overflow";
480  }
481  if(verbosity_>2) cout << "[Matacq " << now() << "] Event found. Reading "
482  " matacq event." << "\n";
483  if(!mread((char*)&data_[0], len*8, "Reading matacq event")){
484  if(verbosity_>2) cout << "[Matacq " << now() << "] Failed to read matacq event."
485  << "\n";
486  state = failed;
487  }
488  matacq_ = MatacqRawEvent((unsigned char*)&data_[0], len*8);
489  } else {
490  if((searchBackward && (orb < orbitId))
491  || (!searchBackward && (orb > orbitId))){ //search ended
492  lastOrb_ = orb;
493  state = failed;
494  if(verbosity_>2) cout << "[Matacq " << now()
495  << "] No matacq data found for run " << run
496  << ", orbit ID " << orbitId << "." << "\n";
497  } else{
498  off_t offset = (searchBackward?-len:len)*8;
499  lastOrb_ = orb;
500  if(verbosity_>3){
501  cout << "[Matacq " << now() << "] In matacq file, moving "
502  << abs(offset) << " byte " << (offset>0?"forward":"backward")
503  << ".\n";
504  }
505 
506  if(mseek(offset, SEEK_CUR,
507  (searchBackward?"Moving to previous event":
508  "Moving to next event"))
509  && mread((char*)&data_[0], headerSize, "Reading event header",
510  true)){
511  } else{
512  if(!searchBackward) mseek(-len*8, SEEK_CUR,
513  "Moving to start of last complete event");
514  state = failed;
515  }
516  }
517  }
518  }
519 
520  if(state==found){
521  filepos_t pos = -1;
522  filepos_t fsize = -1;
523  mtell(pos);
524  msize(fsize);
525  if(pos==fsize-1){ //last byte.
526  if(verbosity_>2){
527  cout << "[Matacq " << now() << "] Event found was at the end of the file. Moving "
528  "stream position to beginning of this event."
529  << "\n";
530  }
531  mseek(-(int)len*8-1, SEEK_CUR,
532  "Moving to beginning of last matacq event");
533  }
534  }
535  return (state==found);
536 }
std::string inFileName_
static int orbitTolerance_
unsigned getRunNum() const
#define abs(x)
Definition: mlp_lapack.h:159
uint32_t getOrbitId() const
unsigned getDccLen() const
int64_t pos(int orb) const
bool mread(char *buf, size_t n, const char *mess=0, bool peek=false)
unsigned int offset(bool)
unsigned long long uint64_t
Definition: Time.h:15
PosEstimator posEstim_
bool mtell(filepos_t &pos)
char state
Definition: procUtils.cc:75
static std::string now()
bool mseek(filepos_t offset, int whence=SEEK_SET, const char *mess=0)
MatacqRawEvent matacq_
tuple cout
Definition: gather_cfg.py:121
bool msize(filepos_t &s)
std::vector< unsigned char > data_
bool MatacqProducer::getMatacqFile ( uint32_t  runNumber,
uint32_t  orbitId,
bool *  fileChange = 0 
)
private

Retrieve the file containing a given matacq event

Parameters
runNumberNumber of the run the matacq event is looking from
orbitIdId of the orbit of the matacq event
fileChangeif not null pointer, set to true if the file changed.
Returns
true if file retrieval succeeded, false otherwise. found.

Definition at line 540 of file MatacqProducer.cc.

References gather_cfg::cout, eventSkipCounter_, fileNames_, alignmentValidation::fname, diffTreeTool::format(), newFWLiteAna::found, i, MatacqProducer::PosEstimator::init(), lastOrb_, mcheck(), misOpened(), mopen(), now(), onErrorDisablingEvtCnt_, openedFileRunNumber_, posEstim_, convertSQLiteXML::runNumber, runSubDir(), and verbosity_.

Referenced by addMatacqData().

541  {
544  if(fileChange!=0) *fileChange = false;
545  return misOpened();
546  }
547 
548  if(fileNames_.size()==0) return 0;
549 
550  const string runNumberFormat = "%08d";
551  string sRunNumber = str(boost::format(runNumberFormat) % runNumber);
552  //cout << "Run number string: " << sRunNumber << "\n";
553  bool found = false;
554  string fname;
555  for(unsigned i=0; i < fileNames_.size() && !found; ++i){
556  fname = fileNames_[i];
557  boost::algorithm::replace_all(fname, "%run_subdir%",
559  boost::algorithm::replace_all(fname, "%run_number%", sRunNumber);
560 
561  if(verbosity_>0) cout << "[Matacq " << now() << "] "
562  << "Looking for a file with path "
563  << fname << "\n";
564 
565  if(mcheck(fname)){
566  LogInfo("Matacq") << "Uses matacq data file: '" << fname << "'\n";
567  found = true;
568  }
569  }
570  if(!found){
571  if(verbosity_>=0) cout << "[Matacq " << now() << "] no matacq file found "
572  "for run " << runNumber << "\n";
575  if(fileChange!=0) *fileChange = false;
576  return 0;
577  }
578 
579  if(!mopen(fname)){
580  LogWarning("Matacq") << "Failed to open file " << fname << "\n";
583  if(fileChange!=0) *fileChange = false;
584  return false;
585  } else{
587  lastOrb_ = 0;
588  posEstim_.init(this);
589  if(fileChange!=0) *fileChange = true;
590  return true;
591  }
592 }
int i
Definition: DBlmapReader.cc:9
std::vector< std::string > fileNames_
bool mcheck(const std::string &name)
static std::string runSubDir(uint32_t runNumber)
uint32_t openedFileRunNumber_
PosEstimator posEstim_
void init(MatacqProducer *mp)
string fname
main script
static std::string now()
tuple cout
Definition: gather_cfg.py:121
bool mopen(const std::string &name)
uint32_t MatacqProducer::getOrbitId ( edm::Event ev) const
private

Definition at line 599 of file MatacqProducer.cc.

References abs, FEDRawData::data(), data, edm::hlt::Exception, edm::Event::getByLabel(), edm::EventBase::id(), inputRawCollection_, FEDNumbering::inRange(), edm::HandleBase::isValid(), orbitTolerance_, lumiPlot::rawdata, and FEDRawData::size().

Referenced by addMatacqData().

599  {
600  //on CVS HEAD (June 4, 08), class Event has a method orbitNumber()
601  //we could use here. The code would be shorten to:
602  //return ev.orbitNumber();
603  //we have to deal with what we have in current CMSSW releases:
605  ev.getByLabel(inputRawCollection_, rawdata);
606  if(!(rawdata.isValid())){
607  throw cms::Exception("NotFound")
608  << "No FED raw data collection found. ECAL raw data are "
609  "required to retrieve the orbit ID";
610  }
611 
612  int orbit = 0;
613  for(int id=601; id<=654; ++id){
614  if(!FEDNumbering::inRange(id)) continue;
615  const FEDRawData& data = rawdata->FEDData(id);
616  const int orbitIdOffset64 = 3;
617  if(data.size()>=8*(orbitIdOffset64+1)){//orbit id is in 4th 64-bit word
618  const unsigned char* pOrbit = data.data() + orbitIdOffset64*8;
619  int thisOrbit = pOrbit[0]
620  | (pOrbit[1] <<8)
621  | (pOrbit[2] <<16)
622  | (pOrbit[3] <<24);
623  if(orbit!=0 && thisOrbit!=0 && abs(orbit-thisOrbit)>orbitTolerance_){
624  //throw cms::Exception("EventCorruption")
625  // << "Orbit ID inconsitency in DCC headers";
626  LogWarning("EventCorruption")
627  << "Orbit ID inconsitency in DCC headers";
628  orbit = 0;
629  break;
630  }
631  if(thisOrbit!=0) orbit = thisOrbit;
632  }
633  }
634 
635  if(orbit==0){
636  // throw cms::Exception("NotFound")
637  // << "Failed to retrieve orbit ID of event "<< ev.id();
638  LogWarning("NotFound") << "Failed to retrieve orbit ID of event "
639  << ev.id();
640  }
641  return orbit;
642 }
static int orbitTolerance_
#define abs(x)
Definition: mlp_lapack.h:159
size_t size() const
Lenght of the data buffer in bytes.
Definition: FEDRawData.h:49
edm::InputTag inputRawCollection_
bool isValid() const
Definition: HandleBase.h:76
bool getByLabel(InputTag const &tag, Handle< PROD > &result) const
Definition: Event.h:361
static bool inRange(int)
edm::EventID id() const
Definition: EventBase.h:56
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:82
const unsigned char * data() const
Return a const pointer to the beginning of the data buffer.
Definition: FEDRawData.cc:29
dictionary rawdata
Definition: lumiPlot.py:393
uint32_t MatacqProducer::getRunNumber ( edm::Event ev) const
private

Definition at line 595 of file MatacqProducer.cc.

References edm::Event::run().

Referenced by addMatacqData(), and produce().

595  {
596  return ev.run();
597 }
RunNumber_t run() const
Definition: Event.h:76
void MatacqProducer::loadOrbitOffset ( )
private

Loading orbit correction table from file.

See Also
orbitOffsetFile_

Definition at line 777 of file MatacqProducer.cc.

References gather_cfg::cout, edm::hlt::Exception, f, ntuplemaker::iline, max(), now(), orbitOffset_, orbitOffsetFile_, DTTTrigCorrFirst::run, and alignCSCRings::s.

Referenced by MatacqProducer().

777  {
778  ifstream f(orbitOffsetFile_.c_str());
779  if(f.bad()){
780  throw cms::Exception("Matacq")
781  << "Failed to open orbit ID correction file '"
782  << orbitOffsetFile_ << "'\n";
783  }
784 
785  cout << "[Matacq " << now() << "] "
786  << "Offset to substract to Matacq events Orbit ID: \n"
787  << "#Run Number\t Offset\n";
788 
789  int iline = 0;
790  string s;
791  stringstream buf;
792  while(f.eof()){
793  getline(f, s);
794  ++iline;
795  if(s[0]=='#'){//comment
796  //skip line:
797  f.ignore(numeric_limits<streamsize>::max(), '\n');
798  continue;
799  }
800  buf.str("");
801  buf << s;
802  int run;
803  int orbit;
804  buf >> run;
805  buf >> orbit;
806  if(buf.bad()){
807  throw cms::Exception("Matacq")
808  << "Syntax error in Orbit offset file '"
809  << orbitOffsetFile_ << "'";
810  }
811  cout << run << "\t" << orbit << "\n";
812  orbitOffset_.insert(pair<int, int>(run, orbit));
813  }
814 }
std::map< uint32_t, uint32_t > orbitOffset_
const T & max(const T &a, const T &b)
double f[11][100]
std::string orbitOffsetFile_
static std::string now()
tuple cout
Definition: gather_cfg.py:121
bool MatacqProducer::mcheck ( const std::string &  name)
private

Definition at line 1002 of file MatacqProducer.cc.

Referenced by getMatacqFile().

1002  {
1003  struct stat dummy;
1004  return 0==stat(name.c_str(), &dummy);
1005 // if(stat(name.c_str(), &dummy)==0){
1006 // return true;
1007 // } else{
1008 // cout << "[Matacq " << now() << "] Failed to stat file '"
1009 // << name.c_str() << "'. "
1010 // << "Error " << errno << ": " << strerror(errno) << "\n";
1011 // return false;
1012 // }
1013 }
void MatacqProducer::mclose ( )
private

Definition at line 1027 of file MatacqProducer.cc.

References inFile_.

Referenced by mopen(), and ~MatacqProducer().

1027  {
1028  if(inFile_!=0) fclose(inFile_);
1029  inFile_ = 0;
1030 }
bool MatacqProducer::meof ( )
private

Definition at line 1036 of file MatacqProducer.cc.

References inFile_.

1036  {
1037  if(0==inFile_) return true;
1038  return feof(inFile_)==0;
1039 }
bool MatacqProducer::misOpened ( )
private

Definition at line 1032 of file MatacqProducer.cc.

References inFile_.

Referenced by getMatacqFile().

1032  {
1033  return inFile_!=0;
1034 }
bool MatacqProducer::mopen ( const std::string &  name)
private

Definition at line 1015 of file MatacqProducer.cc.

References inFile_, inFileName_, mclose(), and mergeVDriftHistosByStation::name.

Referenced by getMatacqFile().

1015  {
1016  if(inFile_!=0) mclose();
1017  inFile_ = fopen(name.c_str(), "r");
1018  if(inFile_!=0){
1019  inFileName_ = name;
1020  return true;
1021  } else{
1022  inFileName_ = "";
1023  return false;
1024  }
1025 }
std::string inFileName_
bool MatacqProducer::mread ( char *  buf,
size_t  n,
const char *  mess = 0,
bool  peek = false 
)
private

Read a data block from input file. On failure file position is restored and if position restoring fails, file is rewind.

Parameters
bufbuffer to store read data
nsize of data block
messtext to insert in the eventual error message.
peekif true file position is restored after the data read
Returns
true on success, false on failure

Definition at line 956 of file MatacqProducer.cc.

References gather_cfg::cout, inFile_, lastOrb_, mrewind(), now(), and verbosity_.

Referenced by getMatacqEvent(), and MatacqProducer::PosEstimator::init().

956  {
957  if(0==inFile_) return false;
958  off_t pos = ftello(inFile_);
959  bool rc = (pos!=-1) && (1==fread(buf, n, 1, inFile_));
960  if(!rc){
961  if(verbosity_){
962  cout << "[Matacq " << now() << "] ";
963  if(mess) cout << mess << ". ";
964  cout << "Read failure from input matacq file.\n";
965  }
966  clearerr(inFile_);
967  }
968  if(peek || !rc){//need to restore file position
969  if(0!=fseeko(inFile_, pos, SEEK_SET)){
970  if(verbosity_){
971  cout << "[Matacq " << now() << "] ";
972  if(mess) cout << mess << ". ";
973  cout << "Failed to restore file position of "
974  "before read error. Rewind file.\n";
975  }
976  //rewind(inFile_.get());
977  mrewind();
978  lastOrb_ = 0;
979  }
980  }
981  return rc;
982 }
static std::string now()
tuple cout
Definition: gather_cfg.py:121
bool MatacqProducer::mrewind ( )
private

Definition at line 996 of file MatacqProducer.cc.

References inFile_.

Referenced by getMatacqEvent(), MatacqProducer::PosEstimator::init(), mread(), and mseek().

996  {
997  if(0==inFile_) return false;
998  clearerr(inFile_);
999  return fseeko(inFile_, 0, SEEK_SET)!=0;
1000 }
bool MatacqProducer::mseek ( filepos_t  offset,
int  whence = SEEK_SET,
const char *  mess = 0 
)
private

Move input file read pointer. On failure file is rewind.

Parameters
bufbuffer to store read data
nsize of data block
messtext to insert in the eventual error message.
Returns
true on success, false on failure

Definition at line 936 of file MatacqProducer.cc.

References gather_cfg::cout, inFile_, mrewind(), now(), and verbosity_.

Referenced by getMatacqEvent(), and MatacqProducer::PosEstimator::init().

936  {
937  if(0==inFile_) return false;
938  const int rc = fseeko(inFile_, offset, whence);
939  if(rc!=0 && verbosity_){
940  cout << "[Matacq " << now() << "] ";
941  if(mess) cout << mess << ". ";
942  cout << "Random access error on input matacq file. "
943  "Rewind file.\n";
944  mrewind();
945  }
946  return rc==0;
947 }
unsigned int offset(bool)
static std::string now()
tuple cout
Definition: gather_cfg.py:121
bool MatacqProducer::msize ( filepos_t s)
private

Definition at line 984 of file MatacqProducer.cc.

References inFile_.

Referenced by getMatacqEvent(), and MatacqProducer::PosEstimator::init().

984  {
985  if(0==inFile_) return false;
986  struct stat buf;
987  if(0!=fstat(fileno(inFile_), &buf)){
988  s = 0;
989  return false;
990  } else{
991  s = buf.st_size;
992  return true;
993  }
994 }
bool MatacqProducer::mtell ( filepos_t pos)
private

Definition at line 949 of file MatacqProducer.cc.

References inFile_.

Referenced by getMatacqEvent().

949  {
950  if(0==inFile_) return false;
951  pos = ftello(inFile_);
952  return pos != -1;
953 
954 }
void MatacqProducer::newRun ( int  prevRun,
int  newRun 
)
private

Definition at line 1050 of file MatacqProducer.cc.

References eventSkipCounter_, logFile_, MatacqProducer::stats_t::nEvents, MatacqProducer::stats_t::nLaserEventsWithMatacq, MatacqProducer::stats_t::nNonLaserEventsWithMatacq, now(), runNumber_, and stats_.

Referenced by produce().

1050  {
1051  runNumber_ = newRun;
1052  eventSkipCounter_ = 0;
1053  logFile_ << "[" << now() << "] Event count for run "
1054  << runNumber_ << ": "
1055  << "total: " << stats_.nEvents << ", "
1056  << "Laser event with Matacq data: "
1057  << stats_.nLaserEventsWithMatacq << ", "
1058  << "Non laser event (according to DCC header) with Matacq data: "
1059  << stats_.nNonLaserEventsWithMatacq << "\n" << flush;
1060 
1061  stats_.nEvents = 0;
1064 
1065 
1066 }
uint32_t runNumber_
std::ofstream logFile_
struct MatacqProducer::stats_t stats_
static std::string now()
void newRun(int prevRun, int newRun)
void MatacqProducer::produce ( edm::Event event,
const edm::EventSetup eventSetup 
)
virtual

Produces the EDM products

Parameters
CMSevent
eventSetupevent conditions

Implements edm::EDProducer.

Definition at line 144 of file MatacqProducer.cc.

References addMatacqData(), gather_cfg::cout, disabled_, getRunNumber(), logTiming_, MatacqProducer::stats_t::nEvents, newRun(), now(), convertSQLiteXML::runNumber, runNumber_, startTime_, stats_, lumiQTWidget::t, timeLog_, timer_, and verbosity_.

Referenced by JSONExport.JsonExport::export(), HTMLExport.HTMLExport::export(), and HTMLExport.HTMLExportStatic::export().

144  {
145  if(verbosity_>=4) cout << "[Matacq " << now() << "] in MatacqProducer::produce" << endl;
146  if(logTiming_){
147  timeval t;
148  gettimeofday(&t, 0);
149 
150  timeLog_ << t.tv_sec << "."
151  << setfill('0') << setw(3) << (t.tv_usec+500)/1000 << setfill(' ')<< "\t"
152  << (t.tv_usec - timer_.tv_usec)*1.
153  + (t.tv_sec - timer_.tv_sec)*1.e6 << "\t";
154  timer_ = t;
155  }
156 
157  if(startTime_.tv_sec==0) gettimeofday(&startTime_, 0);
158  ++stats_.nEvents;
159  if(disabled_) return;
160  const uint32_t runNumber = getRunNumber(event);
161  if(runNumber!=runNumber_){
162  newRun(runNumber_, runNumber);
163  }
164  addMatacqData(event);
165 
166  if(logTiming_){
167  timeval t;
168  gettimeofday(&t, 0);
169  timeLog_ << (t.tv_usec - timer_.tv_usec)*1.
170  + (t.tv_sec - timer_.tv_sec)*1.e6 << "\n";
171  timer_ = t;
172  }
173 }
uint32_t runNumber_
std::ofstream timeLog_
uint32_t getRunNumber(edm::Event &ev) const
struct MatacqProducer::stats_t stats_
void addMatacqData(edm::Event &event)
static std::string now()
tuple cout
Definition: gather_cfg.py:121
void newRun(int prevRun, int newRun)
std::string MatacqProducer::runSubDir ( uint32_t  runNumber)
staticprivate

Definition at line 1043 of file MatacqProducer.cc.

References diffTreeTool::format(), and create_public_lumi_plots::units.

Referenced by getMatacqFile().

1043  {
1044  int millions = runNumber / (1000*1000);
1045  int thousands = (runNumber-millions*1000*1000) / 1000;
1046  int units = runNumber-millions*1000*1000 - thousands*1000;
1047  return str(boost::format("%03d/%03d/%03d") % millions % thousands % units);
1048 }

Member Data Documentation

const int MatacqProducer::bufferSize = 30000
staticprivate

Definition at line 256 of file MatacqProducer.h.

Referenced by addMatacqData().

std::vector<unsigned char> MatacqProducer::data_
private

Definition at line 258 of file MatacqProducer.h.

Referenced by addMatacqData(), and getMatacqEvent().

std::string MatacqProducer::digiInstanceName_
private

Instance name to use for the produced Matacq digi collection

Definition at line 210 of file MatacqProducer.h.

Referenced by addMatacqData(), and MatacqProducer().

bool MatacqProducer::disabled_
private

Parameter to disable matacq data production. For timing purpose.

Definition at line 222 of file MatacqProducer.h.

Referenced by produce().

bool MatacqProducer::doOrbitOffset_
private

Switch for orbit ID correction.

See Also
orbitOffsetFile_

Definition at line 281 of file MatacqProducer.h.

Referenced by addMatacqData(), and MatacqProducer().

int MatacqProducer::eventSkipCounter_
private

counter for event skipping

Definition at line 307 of file MatacqProducer.h.

Referenced by addMatacqData(), getMatacqFile(), and newRun().

int MatacqProducer::fastRetrievalThresh_
private

Definition at line 263 of file MatacqProducer.h.

Referenced by getMatacqEvent().

std::vector<std::string> MatacqProducer::fileNames_
private

Definition at line 206 of file MatacqProducer.h.

Referenced by getMatacqFile().

MatacqDataFormatter MatacqProducer::formatter_
private

Definition at line 259 of file MatacqProducer.h.

Referenced by addMatacqData().

bool MatacqProducer::ignoreTriggerType_
private

When true look for matacq data independently of trigger type.

Definition at line 248 of file MatacqProducer.h.

Referenced by addMatacqData().

FILE_t MatacqProducer::inFile_
private

Stream of currently opened matacq file

Definition at line 254 of file MatacqProducer.h.

Referenced by mclose(), meof(), misOpened(), mopen(), mread(), mrewind(), mseek(), msize(), and mtell().

std::string MatacqProducer::inFileName_
private

Name of currently opened matacq file

Definition at line 285 of file MatacqProducer.h.

Referenced by getMatacqEvent(), and mopen().

edm::InputTag MatacqProducer::inputRawCollection_
private

Name of raw data collection the Matacq data must be merge to if merging is enabled.

Definition at line 239 of file MatacqProducer.h.

Referenced by addMatacqData(), getCalibTriggerType(), and getOrbitId().

int32_t MatacqProducer::lastOrb_
private

Definition at line 262 of file MatacqProducer.h.

Referenced by getMatacqEvent(), getMatacqFile(), and mread().

std::ofstream MatacqProducer::logFile_
private

Log file

Definition at line 302 of file MatacqProducer.h.

Referenced by MatacqProducer(), and newRun().

std::string MatacqProducer::logFileName_
private

Log file name

Definition at line 298 of file MatacqProducer.h.

Referenced by MatacqProducer().

bool MatacqProducer::logTiming_
private

Switch for code timing.

Definition at line 326 of file MatacqProducer.h.

Referenced by MatacqProducer(), produce(), and ~MatacqProducer().

MatacqRawEvent MatacqProducer::matacq_
private

Definition at line 250 of file MatacqProducer.h.

Referenced by addMatacqData(), and getMatacqEvent().

const int MatacqProducer::matacqFedId_ = 655
staticprivate

Definition at line 287 of file MatacqProducer.h.

Referenced by addMatacqData().

bool MatacqProducer::mergeRaw_
private

Switch for merging Matacq raw data with existing raw data collection.

Definition at line 244 of file MatacqProducer.h.

Referenced by addMatacqData().

int MatacqProducer::onErrorDisablingEvtCnt_
private

Number of events to skip in case of error

Definition at line 311 of file MatacqProducer.h.

Referenced by getMatacqFile().

uint32_t MatacqProducer::openedFileRunNumber_
private

Definition at line 261 of file MatacqProducer.h.

Referenced by getMatacqFile().

std::map<uint32_t,uint32_t> MatacqProducer::orbitOffset_
private

Orbit offset table.

See Also
orbitOffsetFile_

Definition at line 277 of file MatacqProducer.h.

Referenced by addMatacqData(), and loadOrbitOffset().

std::string MatacqProducer::orbitOffsetFile_
private

File name of table with orbit offset between matacq event and DCC. Used to recover data suffering from orbit miss-synchonization

Definition at line 273 of file MatacqProducer.h.

Referenced by loadOrbitOffset(), and MatacqProducer().

int MatacqProducer::orbitTolerance_ = 80
staticprivate

Definition at line 260 of file MatacqProducer.h.

Referenced by getMatacqEvent(), and getOrbitId().

PosEstimator MatacqProducer::posEstim_
private

Definition at line 265 of file MatacqProducer.h.

Referenced by getMatacqEvent(), getMatacqFile(), and MatacqProducer().

bool MatacqProducer::produceDigis_
private

Swictch for Matacq digi producion

Definition at line 230 of file MatacqProducer.h.

Referenced by addMatacqData(), and MatacqProducer().

bool MatacqProducer::produceRaw_
private

Switch for Matacq FED raw data production

Definition at line 234 of file MatacqProducer.h.

Referenced by addMatacqData(), and MatacqProducer().

std::string MatacqProducer::rawInstanceName_
private

Instance name to use for the produced Matacq raw data collection

Definition at line 214 of file MatacqProducer.h.

Referenced by addMatacqData(), and MatacqProducer().

uint32_t MatacqProducer::runNumber_
private

Number of the currently processed run

Definition at line 330 of file MatacqProducer.h.

Referenced by newRun(), and produce().

timeval MatacqProducer::startTime_
private

Definition at line 267 of file MatacqProducer.h.

Referenced by MatacqProducer(), produce(), and ~MatacqProducer().

struct MatacqProducer::stats_t MatacqProducer::stats_
private

Referenced by addMatacqData(), newRun(), and produce().

MatacqProducer::stats_t MatacqProducer::stats_init = {0,0,0}
staticprivate

Definition at line 295 of file MatacqProducer.h.

std::ofstream MatacqProducer::timeLog_
private

Output stream to log code timing

Definition at line 322 of file MatacqProducer.h.

Referenced by MatacqProducer(), and produce().

std::string MatacqProducer::timeLogFile_
private

Name of file to log timing

Definition at line 315 of file MatacqProducer.h.

Referenced by MatacqProducer().

timeval MatacqProducer::timer_
private

Buffer for timing

Definition at line 318 of file MatacqProducer.h.

Referenced by MatacqProducer(), and produce().

bool MatacqProducer::timing_
private

Parameter to switch module timing.

Definition at line 218 of file MatacqProducer.h.

int MatacqProducer::verbosity_
private