CMS 3D CMS Logo
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
List of all members | Public Member Functions | Protected Member Functions | Private Member Functions | Private Attributes
BeamSpotDipServer Class Reference

#include <BeamSpotDipServer.h>

Inheritance diagram for BeamSpotDipServer:
DQMOneLumiEDAnalyzer<> DQMOneEDAnalyzer< edm::EndLuminosityBlockProducer, edm::one::WatchLuminosityBlocks, Args...> edm::one::EDProducer< edm::EndRunProducer, edm::one::WatchRuns, edm::Accumulator, Args...> edm::one::EDProducerBase edm::ProducerBase edm::EDConsumerBase edm::ProductRegistryHelper

Public Member Functions

 BeamSpotDipServer (const edm::ParameterSet &)
 
- Public Member Functions inherited from DQMOneLumiEDAnalyzer<>
void accumulate (edm::Event const &event, edm::EventSetup const &setup) override
 
void beginLuminosityBlock (edm::LuminosityBlock const &lumi, edm::EventSetup const &setup) final
 
 DQMOneLumiEDAnalyzer ()
 
void endLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) final
 
void endLuminosityBlockProduce (edm::LuminosityBlock &lumi, edm::EventSetup const &setup) final
 
bool getCanSaveByLumi () override
 
- Public Member Functions inherited from DQMOneEDAnalyzer< edm::EndLuminosityBlockProducer, edm::one::WatchLuminosityBlocks, Args...>
void accumulate (edm::Event const &event, edm::EventSetup const &setup) override
 
void beginRun (edm::Run const &run, edm::EventSetup const &setup) final
 
 DQMOneEDAnalyzer ()
 
void endRun (edm::Run const &, edm::EventSetup const &) final
 
void endRunProduce (edm::Run &run, edm::EventSetup const &setup) final
 
- Public Member Functions inherited from edm::one::EDProducer< edm::EndRunProducer, edm::one::WatchRuns, edm::Accumulator, Args...>
 EDProducer ()=default
 
 EDProducer (const EDProducer &)=delete
 
SerialTaskQueue * globalLuminosityBlocksQueue () final
 
SerialTaskQueue * globalRunsQueue () final
 
bool hasAbilityToProduceInBeginLumis () const final
 
bool hasAbilityToProduceInBeginProcessBlocks () const final
 
bool hasAbilityToProduceInBeginRuns () const final
 
bool hasAbilityToProduceInEndLumis () const final
 
bool hasAbilityToProduceInEndProcessBlocks () const final
 
bool hasAbilityToProduceInEndRuns () const final
 
const EDProducer & operator= (const EDProducer &)=delete
 
bool wantsGlobalLuminosityBlocks () const final
 
bool wantsGlobalRuns () const final
 
bool wantsInputProcessBlocks () const final
 
bool wantsProcessBlocks () const final
 
- Public Member Functions inherited from edm::one::EDProducerBase
 EDProducerBase ()
 
ModuleDescription const & moduleDescription () const
 
bool wantsStreamLuminosityBlocks () const
 
bool wantsStreamRuns () const
 
 ~EDProducerBase () override
 
- Public Member Functions inherited from edm::ProducerBase
void callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)
 
std::vector
< edm::ProductResolverIndex >
const & 		indiciesForPutProducts (BranchType iBranchType) const
 
 ProducerBase ()
 
std::vector
< edm::ProductResolverIndex >
const & 		putTokenIndexToProductResolverIndex () const
 
void registerProducts (ProducerBase *, ProductRegistry *, ModuleDescription const &)
 
std::function< void(BranchDescription
const &)> 		registrationCallback () const
 used by the fwk to register list of products More...
 
void resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel)
 
 ~ProducerBase () noexcept(false) override
 
- Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo > consumesInfo () const
 
void convertCurrentProcessAlias (std::string const &processName)
 Convert "@currentProcess" in InputTag process names to the actual current process name. More...
 
 EDConsumerBase ()
 
 EDConsumerBase (EDConsumerBase const &)=delete
 
 EDConsumerBase (EDConsumerBase &&)=default
 
ESProxyIndex const * esGetTokenIndices (edm::Transition iTrans) const
 
std::vector< ESProxyIndex > const & esGetTokenIndicesVector (edm::Transition iTrans) const
 
std::vector< ESRecordIndex >
const & 		esGetTokenRecordIndicesVector (edm::Transition iTrans) const
 
ProductResolverIndexAndSkipBit indexFrom (EDGetToken, BranchType, TypeID const &) const
 
void itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const
 
void itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const
 
std::vector
< ProductResolverIndexAndSkipBit >
const & 		itemsToGetFrom (BranchType iType) const
 
void labelsForToken (EDGetToken iToken, Labels &oLabels) const
 
void modulesWhoseProductsAreConsumed (std::array< std::vector< ModuleDescription const * > *, NumBranchTypes > &modulesAll, std::vector< ModuleProcessName > &modulesInPreviousProcesses, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const
 
EDConsumerBase const & operator= (EDConsumerBase const &)=delete
 
EDConsumerBase & operator= (EDConsumerBase &&)=default
 
bool registeredToConsume (ProductResolverIndex, bool, BranchType) const
 
bool registeredToConsumeMany (TypeID const &, BranchType) const
 
void selectInputProcessBlocks (ProductRegistry const &productRegistry, ProcessBlockHelperBase const &processBlockHelperBase)
 
ProductResolverIndexAndSkipBit uncheckedIndexFrom (EDGetToken) const
 
void updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)
 
void updateLookup (eventsetup::ESRecordsToProxyIndices const &)
 
virtual ~EDConsumerBase () noexcept(false)
 

Protected Member Functions

void analyze (const edm::Event &e, const edm::EventSetup &) override
 
void bookHistograms (DQMStore::IBooker &, const edm::Run &, const edm::EventSetup &) override
 
void dqmBeginLuminosityBlock (const edm::LuminosityBlock &lumiSeg, const edm::EventSetup &) override
 
void dqmBeginRun (const edm::Run &r, const edm::EventSetup &) override
 
void dqmEndLuminosityBlock (const edm::LuminosityBlock &lumiSeg, const edm::EventSetup &) override
 
void dqmEndRun (const edm::Run &, const edm::EventSetup &iSetup) override
 
- Protected Member Functions inherited from edm::ProducerBase
ProducesCollector producesCollector ()
 
- Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > consumes (edm::InputTag const &tag)
 
template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B > consumes (edm::InputTag tag) noexcept
 
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 ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto esConsumes ()
 
template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto esConsumes (ESInputTag const &tag)
 
template<Transition Tr = Transition::Event>
constexpr auto esConsumes () noexcept
 
template<Transition Tr = Transition::Event>
auto esConsumes (ESInputTag tag) noexcept
 
template<Transition Tr = Transition::Event>
ESGetTokenGeneric esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
 Used with EventSetupRecord::doGet. More...
 
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)
 
void resetItemsToGetFrom (BranchType iType)
 

Private Member Functions

void CMS2LHCRF_POS (float x, float y, float z)
 
void fakeRcd ()
 
std::string getDateTime ()
 
std::string getDateTime (long epoch)
 
long getFileSize (std::string filename)
 
time_t getLastTime (std::string filename)
 
std::vector< std::string > parse (std::string line, const std::string &delimiter)
 
void problem ()
 
void publishRcd (std::string qlty, std::string err, bool pubCMS, bool fitTime)
 
bool readRcd (const BeamSpotOnlineObjects &bs)
 
bool readRcd (std::ifstream &file)
 
std::string tkStatus ()
 
void trueRcd ()
 

Private Attributes

std::bitset< 8 > alive
 
edm::ESGetToken
< BeamSpotOnlineObjects,
BeamSpotOnlineLegacyObjectsRcd > 		bsLegacyToken_
 
float Centroid [3]
 
const int cm2mm = 10
 
const int cm2um = 10000
 
int currentLS = 0
 
edm::InputTag dcsRecordInputTag_
 
edm::EDGetTokenT< DCSRecord > dcsRecordToken_
 
DipFactory * dip
 
float dxdz = 0
 
float dydz = 0
 
std::string endTime = getDateTime()
 
time_t endTimeStamp = 0
 
float err_dxdz = 0
 
float err_dydz = 0
 
float err_meanPV = 0
 
float err_rmsPV = 0
 
float err_sigma_z = 0
 
float err_width_x = 0
 
float err_width_y = 0
 
float err_x = 0
 
float err_y = 0
 
float err_z = 0
 
int events = 0
 
const int intLS = 1
 
long lastFitTime = 0
 
int lastlumi = -1
 
long lastModTime = 0
 
int lsCount = 0
 
std::string lumiRange = "0 - 0"
 
int maxPV = 0
 
float meanPV = 0
 
DipData * messageCMS
 
DipData * messageLHC
 
DipData * messagePV
 
int nPV = 0
 
DipPublication * publicationCMS
 
DipPublication * publicationLHC
 
DipPublication * publicationPV
 
const bool publishStatErrors = true
 
const char * qualities [3] = {"Uncertain", "Bad", "Good"}
 
std::string quality = "Uncertain"
 
const int rad2urad = 1000000
 
bool readFromNFS
 
float rmsPV = 0
 
int runnum
 
float sigma_z = 0
 
float Size [3]
 
std::string sourceFile
 
std::string sourceFile1
 
std::string startTime = getDateTime()
 
time_t startTimeStamp = 0
 
std::string subjectCMS
 
std::string subjectLHC
 
std::string subjectPV
 
bool testing
 
float Tilt [2]
 
std::vector< int > timeoutLS
 
int type = -1
 
bool verbose
 
bool wholeTrackerOn = false
 
float width_x = 0
 
float width_y = 0
 
float x = 0
 
float y = 0
 
float z = 0
 

Additional Inherited Members

- Public Types inherited from DQMOneEDAnalyzer< edm::EndLuminosityBlockProducer, edm::one::WatchLuminosityBlocks, Args...>
typedef dqm::reco::DQMStore DQMStore
 
typedef dqm::reco::MonitorElement MonitorElement
 
- Public Types inherited from edm::one::EDProducerBase
typedef EDProducerBase ModuleType
 
- Public Types inherited from edm::ProducerBase
using ModuleToResolverIndicies = std::unordered_multimap< std::string, std::tuple< edm::TypeID const *, const char *, edm::ProductResolverIndex >>
 
typedef
ProductRegistryHelper::TypeLabelList 		TypeLabelList
 
- Public Types inherited from edm::EDConsumerBase
typedef ProductLabels Labels
 
- Static Public Member Functions inherited from edm::one::EDProducerBase
static const std::string & baseType ()
 
static void fillDescriptions (ConfigurationDescriptions &descriptions)
 
static void prevalidate (ConfigurationDescriptions &descriptions)
 
- Protected Attributes inherited from DQMOneLumiEDAnalyzer<>
edm::EDPutTokenT< DQMToken > lumiToken_
 
- Protected Attributes inherited from DQMOneEDAnalyzer< edm::EndLuminosityBlockProducer, edm::one::WatchLuminosityBlocks, Args...>
edm::EDPutTokenT< DQMToken > runToken_
 

Detailed Description

Definition at line 29 of file BeamSpotDipServer.h.

Constructor & Destructor Documentation

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

Definition at line 34 of file BeamSpotDipServer.cc.

References beamerCreator::create(), edm::ParameterSet::getParameter(), edm::ParameterSet::getUntrackedParameter(), and verbose.

34  {
35  //
36  verbose = ps.getUntrackedParameter<bool>("verbose");
37  testing = ps.getUntrackedParameter<bool>("testing");
38 
39  subjectCMS = ps.getUntrackedParameter<string>("subjectCMS");
40  subjectLHC = ps.getUntrackedParameter<string>("subjectLHC");
41  subjectPV = ps.getUntrackedParameter<string>("subjectPV");
42 
43  readFromNFS = ps.getUntrackedParameter<bool>("readFromNFS");
44  // only if readFromNFS = true
45  sourceFile = ps.getUntrackedParameter<string>("sourceFile"); // beamspot
46  sourceFile1 = ps.getUntrackedParameter<string>("sourceFile1"); // tk status
47 
48  timeoutLS = ps.getUntrackedParameter<vector<int>>("timeoutLS");
49 
50  //
51  bsLegacyToken_ = esConsumes<edm::Transition::EndLuminosityBlock>();
52 
53  dcsRecordInputTag_ = ps.getParameter<edm::InputTag>("dcsRecordInputTag");
54  dcsRecordToken_ = consumes<DCSRecord>(dcsRecordInputTag_);
55 
56  //
57  dip = Dip::create("CmsBeamSpotServer");
58 
59  //
60  dip->setDNSNode("cmsdimns1.cern.ch");
61 
62  edm::LogInfo("BeamSpotDipServer") << "reading from " << (readFromNFS ? "file (NFS)" : "database");
63 }
edm::ParameterSet::getUntrackedParameter
T getUntrackedParameter(std::string const &, T const &) const
BeamSpotDipServer::dcsRecordToken_
edm::EDGetTokenT< DCSRecord > dcsRecordToken_
Definition: BeamSpotDipServer.h:127
BeamSpotDipServer::timeoutLS
std::vector< int > timeoutLS
Definition: BeamSpotDipServer.h:148
BeamSpotDipServer::dcsRecordInputTag_
edm::InputTag dcsRecordInputTag_
Definition: BeamSpotDipServer.h:126
BeamSpotDipServer::bsLegacyToken_
edm::ESGetToken< BeamSpotOnlineObjects, BeamSpotOnlineLegacyObjectsRcd > bsLegacyToken_
Definition: BeamSpotDipServer.h:133
edm::LogInfo
Log< level::Info, false > LogInfo
Definition: MessageLogger.h:125
edm::ParameterSet::getParameter
T getParameter(std::string const &) const
Definition: ParameterSet.h:303

Member Function Documentation

void BeamSpotDipServer::analyze ( const edm::Event &  e,
const edm::EventSetup &   
)
overrideprotectedvirtual

Reimplemented from DQMOneEDAnalyzer< edm::EndLuminosityBlockProducer, edm::one::WatchLuminosityBlocks, Args...>.

Definition at line 106 of file BeamSpotDipServer.cc.

References DCSRecord::BPIX, DCSRecord::FPIX, edm::Event::getByToken(), edm::EventBase::luminosityBlock(), edm::Event::run(), DCSRecord::TECm, DCSRecord::TECp, DCSRecord::TIBTID, DCSRecord::TOB, and verbose.

106  {
107  if (!readFromNFS) {
108  // get runnumber
109  runnum = iEvent.run();
110 
111  // get tracker status if in a new lumisection
112  int nthlumi = iEvent.luminosityBlock();
113 
114  if (nthlumi > lastlumi) { // check every LS
115  lastlumi = nthlumi;
116 
117  edm::Handle<DCSRecord> dcsRecord;
118  iEvent.getByToken(dcsRecordToken_, dcsRecord);
119 
120  wholeTrackerOn =
121  (*dcsRecord).highVoltageReady(DCSRecord::BPIX) && (*dcsRecord).highVoltageReady(DCSRecord::FPIX) &&
122  (*dcsRecord).highVoltageReady(DCSRecord::TIBTID) && (*dcsRecord).highVoltageReady(DCSRecord::TOB) &&
123  (*dcsRecord).highVoltageReady(DCSRecord::TECp) && (*dcsRecord).highVoltageReady(DCSRecord::TECm);
124 
125  if (verbose)
126  edm::LogInfo("BeamSpotDipServer") << "whole tracker on? " << (wholeTrackerOn ? "yes" : "no");
127  }
128  }
129 }
BeamSpotDipServer::dcsRecordToken_
edm::EDGetTokenT< DCSRecord > dcsRecordToken_
Definition: BeamSpotDipServer.h:127
iEvent
int iEvent
Definition: GenABIO.cc:224
edm::LogInfo
Log< level::Info, false > LogInfo
Definition: MessageLogger.h:125
void BeamSpotDipServer::bookHistograms ( DQMStore::IBooker &  ,
const edm::Run &  ,
const edm::EventSetup &   
)
overrideprotectedvirtual

Implements DQMOneEDAnalyzer< edm::EndLuminosityBlockProducer, edm::one::WatchLuminosityBlocks, Args...>.

Definition at line 66 of file BeamSpotDipServer.cc.

66  {
67  // do nothing
68 }
void BeamSpotDipServer::CMS2LHCRF_POS ( float  x,
float  y,
float  z 
)
private

Definition at line 593 of file BeamSpotDipServer.cc.

References x, y, and z.

593  {
594  if (x != 0) { // Rotation + Translation + Inversion + Scaling
595  double tmpx = x;
596  // x*rotY[0]*rotZ[0] + y*rotY[0]*rotZ[1] - z*rotY[1] + trans[0];
597  Centroid[0] = tmpx;
598  Centroid[0] *= -1.0 * cm2um;
599  } else
600  Centroid[0] = x;
601 
602  if (y != 0) { // Rotation + Translation + Scaling
603  double tmpy = y;
604  // x*(rotX[1]*rotY[1]*rotZ[0] - rotX[0]*rotZ[1]) +
605  // y*(rotX[0]*rotZ[0] + rotX[1]*rotY[1]*rotZ[1]) +
606  // z*rotX[1]*rotY[0] + trans[1];
607  Centroid[1] = tmpy;
608  Centroid[1] *= cm2um;
609  } else
610  Centroid[1] = y;
611 
612  if (z != 0) { // Rotation + Translation + Inversion + Scaling
613  double tmpz = z;
614  // x*(rotX[0]*rotY[1]*rotZ[0] + rotX[1]*rotZ[1]) +
615  // y*(rotX[0]*rotY[1]*rotZ[1] - rotX[1]*rotZ[0]) +
616  // z*rotX[0]*rotY[0] + trans[2];
617  Centroid[2] = tmpz;
618  Centroid[2] *= -1.0 * cm2mm;
619  } else
620  Centroid[2] = z;
621 }
void BeamSpotDipServer::dqmBeginLuminosityBlock ( const edm::LuminosityBlock &  lumiSeg,
const edm::EventSetup &   
)
overrideprotectedvirtual

Reimplemented from DQMOneLumiEDAnalyzer<>.

Definition at line 101 of file BeamSpotDipServer.cc.

101  {
102  // do nothing
103 }
void BeamSpotDipServer::dqmBeginRun ( const edm::Run &  r,
const edm::EventSetup &   
)
overrideprotectedvirtual

Reimplemented from DQMOneEDAnalyzer< edm::EndLuminosityBlockProducer, edm::one::WatchLuminosityBlocks, Args...>.

Definition at line 71 of file BeamSpotDipServer.cc.

References alignCSCRings::e, cppFunctionSkipper::exception, quality, and edm::RunBase::run().

71  {
72  edm::LogInfo("BeamSpotDipServer") << "begin run " << r.run();
73 
74  try {
75  ErrHandler errHandler;
76 
77  edm::LogInfo("BeamSpotDipServer") << "server started at " + getDateTime();
78 
79  edm::LogInfo("BeamSpotDipServer") << "creating publication " + subjectCMS;
80  publicationCMS = dip->createDipPublication(subjectCMS.c_str(), &errHandler);
81  messageCMS = dip->createDipData();
82 
83  edm::LogInfo("BeamSpotDipServer") << "creating publication " + subjectLHC;
84  publicationLHC = dip->createDipPublication(subjectLHC.c_str(), &errHandler);
85  messageLHC = dip->createDipData();
86 
87  edm::LogInfo("BeamSpotDipServer") << "creating publication " + subjectPV;
88  publicationPV = dip->createDipPublication(subjectPV.c_str(), &errHandler);
89  messagePV = dip->createDipData();
90 
91  trueRcd(); // starts with all 0
92  publishRcd("UNINITIALIZED", "", true, false);
93  } catch (exception& e) {
94  edm::LogError("BeamSpotDipServer") << "exception (start up): " << e.what();
95  }
96 
97  quality = qualities[0]; // start with Uncertain
98 }
BeamSpotDipServer::publicationPV
DipPublication * publicationPV
Definition: BeamSpotDipServer.h:83
edm::RunBase::run
RunNumber_t run() const
Definition: RunBase.h:40
BeamSpotDipServer::getDateTime
std::string getDateTime()
Definition: BeamSpotDipServer.cc:773
edm::LogError
Log< level::Error, false > LogError
Definition: MessageLogger.h:123
BeamSpotDipServer::publishRcd
void publishRcd(std::string qlty, std::string err, bool pubCMS, bool fitTime)
Definition: BeamSpotDipServer.cc:712
edm::LogInfo
Log< level::Info, false > LogInfo
Definition: MessageLogger.h:125
BeamSpotDipServer::qualities
const char * qualities[3]
Definition: BeamSpotDipServer.h:62
BeamSpotDipServer::publicationCMS
DipPublication * publicationCMS
Definition: BeamSpotDipServer.h:81
BeamSpotDipServer::publicationLHC
DipPublication * publicationLHC
Definition: BeamSpotDipServer.h:82
void BeamSpotDipServer::dqmEndLuminosityBlock ( const edm::LuminosityBlock &  lumiSeg,
const edm::EventSetup &  iSetup 
)
overrideprotectedvirtual

Reimplemented from DQMOneLumiEDAnalyzer<>.

Definition at line 132 of file BeamSpotDipServer.cc.

References cms::cuda::bs, alignCSCRings::e, cppFunctionSkipper::exception, edm::EventSetup::getHandle(), heppy_check::logFile, edm::LuminosityBlockBase::luminosityBlock(), quality, createJobs::tmp, and verbose.

132  {
133  edm::LogInfo("BeamSpotDipServer") << "--------------------- end of LS " << lumiSeg.luminosityBlock();
134 
135  try {
136  if (readFromNFS) {
137  ifstream logFile(sourceFile);
138 
139  if (!logFile.good()) {
140  edm::LogWarning("BeamSpotDipServer") << "Source File: " + sourceFile + " doesn't exist!";
141  problem();
142  } else {
143  lastModTime = getLastTime(sourceFile);
144 
145  if (lastFitTime == 0)
146  lastFitTime = lastModTime;
147 
148  if (getFileSize(sourceFile) == 0) {
149  // source file has zero length
150  if (lastModTime > lastFitTime) {
151  string tmp = tkStatus();
152  edm::LogInfo("BeamSpotDipServer") << "New run starts. Run number: " << runnum;
153  if (verbose)
154  edm::LogInfo("BeamSpotDipServer") << "Initial lastModTime = " + getDateTime(lastModTime);
155  }
156  lastFitTime = lastModTime;
157  }
158 
159  if (lastModTime > lastFitTime) {
160  // source file modified
161  if (verbose) {
162  edm::LogInfo("BeamSpotDipServer") << "time of last fit = " + getDateTime(lastFitTime);
163  edm::LogInfo("BeamSpotDipServer") << "time of current fit = " + getDateTime(lastModTime);
164  }
165  lastFitTime = lastModTime;
166 
167  // source file length > 0
168  if (getFileSize(sourceFile) > 0) {
169  if (verbose)
170  edm::LogInfo("BeamSpotDipServer") << "reading record from " + sourceFile;
171 
172  if (readRcd(logFile)) {
173  if (verbose)
174  edm::LogInfo("BeamSpotDipServer") << "got new record from file";
175 
176  trueRcd();
177  alive.reset();
178  alive.flip(7);
179  } else {
180  if (verbose)
181  edm::LogInfo("BeamSpotDipServer") << "problem with new record";
182  fakeRcd();
183  }
184 
185  lsCount = 0;
186  }
187  } else {
188  // source file not touched
189  problem();
190  }
191  }
192 
193  logFile.close();
194  } else {
195  edm::ESHandle<BeamSpotOnlineObjects> bsLegacyHandle = iSetup.getHandle(bsLegacyToken_);
196  auto const& bs = *bsLegacyHandle;
197 
198  // from database
199  if (readRcd(bs)) {
200  if (verbose)
201  edm::LogInfo("BeamSpotDipServer") << "got new record from database";
202  trueRcd();
203  alive.reset();
204  alive.flip(7);
205  } else {
206  if (verbose)
207  edm::LogInfo("BeamSpotDipServer") << "problem with new record";
208  fakeRcd();
209  }
210 
211  lsCount = 0;
212  }
213 
214  // quality of the publish results
215  if (testing)
216  publishRcd(qualities[0], "Testing", true, true); // Uncertain
217  else if (quality == qualities[1]) // Bad
218  publishRcd(quality, "No fit or fit fails", true, true);
219  else
220  publishRcd(quality, "", true, true); // Good
221  } catch (exception& e) {
222  edm::LogWarning("BeamSpotDipServer") << "io exception (end of lumi): " << e.what();
223  };
224 }
BeamSpotDipServer::getDateTime
std::string getDateTime()
Definition: BeamSpotDipServer.cc:773
BeamSpotDipServer::readRcd
bool readRcd(const BeamSpotOnlineObjects &bs)
Definition: BeamSpotDipServer.cc:366
edm::LuminosityBlockBase::luminosityBlock
LuminosityBlockNumber_t luminosityBlock() const
Definition: LuminosityBlockBase.h:40
BeamSpotDipServer::alive
std::bitset< 8 > alive
Definition: BeamSpotDipServer.h:72
BeamSpotDipServer::publishRcd
void publishRcd(std::string qlty, std::string err, bool pubCMS, bool fitTime)
Definition: BeamSpotDipServer.cc:712
BeamSpotDipServer::getFileSize
long getFileSize(std::string filename)
Definition: BeamSpotDipServer.cc:243
BeamSpotDipServer::bsLegacyToken_
edm::ESGetToken< BeamSpotOnlineObjects, BeamSpotOnlineLegacyObjectsRcd > bsLegacyToken_
Definition: BeamSpotDipServer.h:133
edm::LogInfo
Log< level::Info, false > LogInfo
Definition: MessageLogger.h:125
heppy_check.logFile
tuple logFile
Definition: heppy_check.py:40
BeamSpotDipServer::getLastTime
time_t getLastTime(std::string filename)
Definition: BeamSpotDipServer.cc:250
BeamSpotDipServer::qualities
const char * qualities[3]
Definition: BeamSpotDipServer.h:62
edm::EventSetup::getHandle
ESHandle< T > getHandle(const ESGetToken< T, R > &iToken) const
Definition: EventSetup.h:157
edm::LogWarning
Log< level::Warning, false > LogWarning
Definition: MessageLogger.h:122
createJobs.tmp
tmp
align.sh
Definition: createJobs.py:716
BeamSpotDipServer::tkStatus
std::string tkStatus()
Definition: BeamSpotDipServer.cc:275
void BeamSpotDipServer::dqmEndRun ( const edm::Run &  ,
const edm::EventSetup &  iSetup 
)
overrideprotectedvirtual

Reimplemented from DQMOneEDAnalyzer< edm::EndLuminosityBlockProducer, edm::one::WatchLuminosityBlocks, Args...>.

Definition at line 227 of file BeamSpotDipServer.cc.

227  {
228  // destroy publications and data
229  edm::LogInfo("BeamSpotDipServer") << "destroying publication " + subjectCMS;
230  dip->destroyDipPublication(publicationCMS);
231  delete messageCMS;
232 
233  edm::LogInfo("BeamSpotDipServer") << "destroying publication " + subjectLHC;
234  dip->destroyDipPublication(publicationLHC);
235  delete messageLHC;
236 
237  edm::LogInfo("BeamSpotDipServer") << "destroying publication " + subjectPV;
238  dip->destroyDipPublication(publicationPV);
239  delete messagePV;
240 }
BeamSpotDipServer::publicationPV
DipPublication * publicationPV
Definition: BeamSpotDipServer.h:83
edm::LogInfo
Log< level::Info, false > LogInfo
Definition: MessageLogger.h:125
BeamSpotDipServer::publicationCMS
DipPublication * publicationCMS
Definition: BeamSpotDipServer.h:81
BeamSpotDipServer::publicationLHC
DipPublication * publicationLHC
Definition: BeamSpotDipServer.h:82
void BeamSpotDipServer::fakeRcd ( )
private

Definition at line 690 of file BeamSpotDipServer.cc.

References cppFunctionSkipper::exception.

690  {
691  try {
692  Centroid[0] = 0;
693  Centroid[1] = 0;
694  Centroid[2] = 0;
695 
696  Size[0] = 0;
697  Size[1] = 0;
698  Size[2] = 0;
699 
700  Tilt[0] = 0;
701  Tilt[1] = 0;
702 
703  messageLHC->insert(Size, 3, "Size");
704  messageLHC->insert(Centroid, 3, "Centroid");
705  messageLHC->insert(Tilt, 2, "Tilt");
706  } catch (exception& e) {
707  edm::LogWarning("BeamSpotDipServer") << "exception (fakeRcd): " << e.what();
708  }
709 }
edm::LogWarning
Log< level::Warning, false > LogWarning
Definition: MessageLogger.h:122
string BeamSpotDipServer::getDateTime ( )
private

Definition at line 773 of file BeamSpotDipServer.cc.

773  {
774  time_t t = time(nullptr);
775 
776  return getDateTime(t);
777 }
BeamSpotDipServer::getDateTime
std::string getDateTime()
Definition: BeamSpotDipServer.cc:773
std::string BeamSpotDipServer::getDateTime ( long  epoch)
private
long BeamSpotDipServer::getFileSize ( std::string  filename)
private

Definition at line 243 of file BeamSpotDipServer.cc.

References edm_modernize_messagelogger::stat.

243  {
244  struct stat stat_buf;
245  int rc = stat(filename.c_str(), &stat_buf);
246  return (rc == 0 ? stat_buf.st_size : -1);
247 }
edm_modernize_messagelogger.stat
stat
Definition: edm_modernize_messagelogger.py:27
lut2db_cfg.filename
tuple filename
Definition: lut2db_cfg.py:20
time_t BeamSpotDipServer::getLastTime ( std::string  filename)
private

Definition at line 250 of file BeamSpotDipServer.cc.

References edm_modernize_messagelogger::stat.

250  {
251  struct stat stat_buf;
252  int rc = stat(filename.c_str(), &stat_buf);
253  return (rc == 0 ? stat_buf.st_mtime : -1);
254 }
edm_modernize_messagelogger.stat
stat
Definition: edm_modernize_messagelogger.py:27
lut2db_cfg.filename
tuple filename
Definition: lut2db_cfg.py:20
vector< string > BeamSpotDipServer::parse ( std::string  line,
const std::string &  delimiter 
)
private

Definition at line 257 of file BeamSpotDipServer.cc.

References unpackBuffers-CaloStage2::token.

257  {
258  vector<string> list;
259 
260  size_t pos = 0;
261  while ((pos = line.find(delimiter)) != string::npos) {
262  string token = line.substr(0, pos);
263 
264  list.push_back(token);
265 
266  line.erase(0, pos + delimiter.length());
267  }
268 
269  list.push_back(line); // remainder
270 
271  return list;
272 }
void BeamSpotDipServer::problem ( )
private

Definition at line 327 of file BeamSpotDipServer.cc.

References verbose.

327  {
328  if (verbose)
329  edm::LogInfo("BeamSpotDipServer") << "no update | alive = " << alive;
330 
331  lsCount++;
332 
333  if ((lsCount % timeoutLS[0] == 0) && (lsCount % timeoutLS[1] != 0)) // first time out
334  {
335  if (!alive.test(1))
336  alive.flip(1);
337  if (!alive.test(2)) {
338  if (!alive.test(7))
339  fakeRcd();
340  else
341  trueRcd();
342 
343  stringstream warnMsg;
344  warnMsg << "No new data for " << lsCount << " LS";
345  publishRcd("Uncertain", warnMsg.str(), false, false);
346  } else {
347  fakeRcd();
348 
349  stringstream warnMsg;
350  warnMsg << "No new data for " << lsCount << " LS: " << tkStatus();
351  publishRcd("Bad", warnMsg.str(), false, false);
352  }
353  } else if (lsCount % timeoutLS[1] == 0) // second time out
354  {
355  if (!alive.test(2))
356  alive.flip(2);
357  fakeRcd();
358 
359  stringstream warnMsg;
360  warnMsg << "No new data for " << lsCount << " LS: " << tkStatus();
361  publishRcd("Bad", warnMsg.str(), false, false);
362  }
363 }
BeamSpotDipServer::timeoutLS
std::vector< int > timeoutLS
Definition: BeamSpotDipServer.h:148
BeamSpotDipServer::alive
std::bitset< 8 > alive
Definition: BeamSpotDipServer.h:72
BeamSpotDipServer::publishRcd
void publishRcd(std::string qlty, std::string err, bool pubCMS, bool fitTime)
Definition: BeamSpotDipServer.cc:712
edm::LogInfo
Log< level::Info, false > LogInfo
Definition: MessageLogger.h:125
BeamSpotDipServer::tkStatus
std::string tkStatus()
Definition: BeamSpotDipServer.cc:275
void BeamSpotDipServer::publishRcd ( std::string  qlty,
std::string  err,
bool  pubCMS,
bool  fitTime 
)
private

Definition at line 712 of file BeamSpotDipServer.cc.

References BeamSpotPI::endTimeStamp, cppFunctionSkipper::exception, and verbose.

712  {
713  try {
714  bool updateCMS = pubCMS && (currentLS % intLS == 0);
715 
716  if (verbose) {
717  edm::LogInfo("BeamSpotDipServer") << "sending (" << qlty << " | " << err << ")";
718 
719  if (alive.test(7)) {
720  if (updateCMS)
721  edm::LogInfo("BeamSpotDipServer") << " to CCC and CMS";
722  else if (!alive.test(1) && !alive.test(2))
723  edm::LogInfo("BeamSpotDipServer") << " to CCC only";
724  }
725  }
726 
727  DipTimestamp zeit;
728  if (fitTime) {
729  long epoch;
730  epoch = endTimeStamp * 1000; // convert to ms
731  zeit = DipTimestamp(epoch);
732  } else
733  zeit = DipTimestamp();
734 
735  // send
736  if (updateCMS)
737  publicationCMS->send(*messageCMS, zeit);
738 
739  publicationLHC->send(*messageLHC, zeit);
740  publicationPV->send(*messagePV, zeit);
741 
742  // set qualities
743  if (qlty == qualities[0]) { // Uncertain
744  if (updateCMS)
745  publicationCMS->setQualityUncertain(err.c_str());
746 
747  publicationLHC->setQualityUncertain(err.c_str());
748  } else if (qlty == qualities[1]) { // Bad
749  if (updateCMS)
750  publicationCMS->setQualityBad(err.c_str());
751 
752  publicationLHC->setQualityBad(err.c_str());
753  } else if (qlty == "UNINITIALIZED") {
754  if (updateCMS)
755  publicationCMS->setQualityBad("UNINITIALIZED");
756 
757  publicationLHC->setQualityBad("UNINITIALIZED");
758  }
759  } catch (exception& e) {
760  edm::LogWarning("BeamSpotDipServer") << "exception (publishRcd): " << e.what();
761  }
762 }
BeamSpotDipServer::publicationPV
DipPublication * publicationPV
Definition: BeamSpotDipServer.h:83
BeamSpotDipServer::alive
std::bitset< 8 > alive
Definition: BeamSpotDipServer.h:72
edm::LogInfo
Log< level::Info, false > LogInfo
Definition: MessageLogger.h:125
BeamSpotDipServer::qualities
const char * qualities[3]
Definition: BeamSpotDipServer.h:62
BeamSpotDipServer::publicationCMS
DipPublication * publicationCMS
Definition: BeamSpotDipServer.h:81
edm::LogWarning
Log< level::Warning, false > LogWarning
Definition: MessageLogger.h:122
BeamSpotDipServer::publicationLHC
DipPublication * publicationLHC
Definition: BeamSpotDipServer.h:82
bool BeamSpotDipServer::readRcd ( const BeamSpotOnlineObjects &  bs)
private

Definition at line 366 of file BeamSpotDipServer.cc.

References BeamSpotPI::dxdz, BeamSpotPI::dydz, alignCSCRings::e, dcs_trend_monitor_cfg::endTime, BeamSpotPI::endTimeStamp, patZpeak::events, cppFunctionSkipper::exception, BeamSpotObjects::GetBeamType(), BeamSpotObjects::GetBeamWidthX(), BeamSpotObjects::GetBeamWidthXError(), BeamSpotObjects::GetBeamWidthYError(), BeamSpotOnlineObjects::GetCreationTime(), BeamSpotObjects::Getdxdz(), BeamSpotObjects::GetdxdzError(), BeamSpotObjects::Getdydz(), BeamSpotObjects::GetdydzError(), BeamSpotOnlineObjects::GetEndTime(), BeamSpotOnlineObjects::GetEndTimeStamp(), BeamSpotOnlineObjects::GetLastAnalyzedLumi(), BeamSpotOnlineObjects::GetLastAnalyzedRun(), BeamSpotOnlineObjects::GetLumiRange(), BeamSpotOnlineObjects::GetMaxPVs(), BeamSpotOnlineObjects::GetMeanErrorPV(), BeamSpotOnlineObjects::GetMeanPV(), BeamSpotOnlineObjects::GetNumPVs(), BeamSpotOnlineObjects::GetRmsErrorPV(), BeamSpotOnlineObjects::GetRmsPV(), BeamSpotObjects::GetSigmaZ(), BeamSpotObjects::GetSigmaZError(), BeamSpotOnlineObjects::GetStartTime(), BeamSpotOnlineObjects::GetStartTimeStamp(), BeamSpotOnlineObjects::GetUsedEvents(), BeamSpotObjects::GetX(), BeamSpotObjects::GetXError(), BeamSpotObjects::GetY(), BeamSpotObjects::GetYError(), BeamSpotObjects::GetZ(), BeamSpotObjects::GetZError(), BeamSpotPI::lumiRange, BeamSpotPI::meanPV, quality, BeamSpotPI::rmsPV, dcs_trend_monitor_cfg::startTime, BeamSpotPI::startTimeStamp, verbose, x, y, and z.

368 {
369  runnum = bs.GetLastAnalyzedRun();
370 
371  // get from BeamSpotOnlineObject
372 
373  try {
374  startTime = bs.GetStartTime();
375  startTimeStamp = bs.GetStartTimeStamp();
376  endTime = bs.GetEndTime();
377  endTimeStamp = bs.GetEndTimeStamp();
378  } catch (exception& e) {
379  edm::LogWarning("BeamSpotDipServer") << "time variables are not available (readRcd): " << e.what();
380 
381  startTime = bs.GetCreationTime();
382  startTimeStamp = bs.GetCreationTime();
383  endTime = bs.GetCreationTime();
384  endTimeStamp = bs.GetCreationTime();
385  }
386 
387  try {
388  lumiRange = bs.GetLumiRange();
389  } catch (exception& e) {
390  edm::LogWarning("BeamSpotDipServer") << "lumirange variable not avaialble (readRcd): " << e.what();
391 
392  lumiRange = to_string(bs.GetLastAnalyzedLumi());
393  }
394 
395  currentLS = bs.GetLastAnalyzedLumi();
396 
397  type = bs.GetBeamType();
398 
399  if (verbose)
400  edm::LogInfo("BeamSpotDipServer") << "run: " << runnum << ", LS: " << currentLS << ", time: " << startTime << " "
401  << startTimeStamp << ", type: " << type;
402 
403  if (testing)
404  quality = qualities[0]; // Uncertain
405  else if (type >= 2)
406  quality = qualities[2]; // Good
407  else
408  quality = qualities[1]; // Bad
409 
410  x = bs.GetX();
411  y = bs.GetY();
412  z = bs.GetZ();
413 
414  sigma_z = bs.GetSigmaZ();
415  dxdz = bs.Getdxdz();
416  dydz = bs.Getdydz();
417  width_x = bs.GetBeamWidthX();
418  width_y = bs.GetBeamWidthX();
419 
420  err_x = bs.GetXError();
421  err_y = bs.GetYError();
422  err_z = bs.GetZError();
423  err_sigma_z = bs.GetSigmaZError();
424  err_dxdz = bs.GetdxdzError();
425  err_dydz = bs.GetdydzError();
426  err_width_x = bs.GetBeamWidthXError();
427  err_width_y = bs.GetBeamWidthYError();
428 
429  try {
430  events = bs.GetUsedEvents();
431  meanPV = bs.GetMeanPV();
432  err_meanPV = bs.GetMeanErrorPV();
433  rmsPV = bs.GetRmsPV();
434  err_rmsPV = bs.GetRmsErrorPV();
435  maxPV = bs.GetMaxPVs();
436  } catch (exception& e) {
437  edm::LogWarning("BeamSpotDipServer") << "PV variables are not available (readRcd): " << e.what();
438 
439  events = 0.;
440  meanPV = 0.;
441  err_meanPV = 0.;
442  rmsPV = 0.;
443  err_rmsPV = 0.;
444  maxPV = 0.;
445  }
446 
447  nPV = bs.GetNumPVs();
448 
449  if (verbose)
450  edm::LogInfo("BeamSpotDipServer") << "pos: (" << x << "," << y << "," << z << ")"
451  << " nPV: " << nPV;
452 
453  return true;
454 }
BeamSpotObjects::Getdydz
double Getdydz() const
get dydz slope, crossing angle in YZ
Definition: BeamSpotObjects.h:81
BeamSpotOnlineObjects::GetStartTime
std::string GetStartTime() const
Definition: BeamSpotOnlineObjects.cc:72
BeamSpotObjects::GetY
double GetY() const
get Y beam position
Definition: BeamSpotObjects.h:69
BeamSpotOnlineObjects::GetCreationTime
cond::Time_t GetCreationTime() const
Definition: BeamSpotOnlineObjects.cc:84
BeamSpotOnlineObjects::GetLumiRange
std::string GetLumiRange() const
Definition: BeamSpotOnlineObjects.cc:80
BeamSpotObjects::GetSigmaZ
double GetSigmaZ() const
get sigma Z, RMS bunch length
Definition: BeamSpotObjects.h:73
BeamSpotOnlineObjects::GetStartTimeStamp
cond::Time_t GetStartTimeStamp() const
Definition: BeamSpotOnlineObjects.cc:88
BeamSpotObjects::GetBeamWidthX
double GetBeamWidthX() const
get average transverse beam width
Definition: BeamSpotObjects.h:75
BeamSpotOnlineObjects::GetLastAnalyzedLumi
int GetLastAnalyzedLumi() const
Getters Methods.
Definition: BeamSpotOnlineObjects.h:100
BeamSpotObjects::GetYError
double GetYError() const
get Y beam position Error
Definition: BeamSpotObjects.h:87
BeamSpotObjects::GetBeamWidthYError
double GetBeamWidthYError() const
get average transverse beam width error X = Y
Definition: BeamSpotObjects.h:95
type
type
Definition: SiPixelVCal_PayloadInspector.cc:39
BeamSpotOnlineObjects::GetEndTime
std::string GetEndTime() const
Definition: BeamSpotOnlineObjects.cc:76
BeamSpotObjects::GetBeamType
int GetBeamType() const
get beam type
Definition: BeamSpotObjects.h:101
BeamSpotObjects::GetdydzError
double GetdydzError() const
get dydz slope, crossing angle in YZ Error
Definition: BeamSpotObjects.h:99
BeamSpotObjects::GetZ
double GetZ() const
get Z beam position
Definition: BeamSpotObjects.h:71
BeamSpotObjects::Getdxdz
double Getdxdz() const
get dxdz slope, crossing angle in XZ
Definition: BeamSpotObjects.h:79
BeamSpotObjects::GetdxdzError
double GetdxdzError() const
get dxdz slope, crossing angle in XZ Error
Definition: BeamSpotObjects.h:97
BeamSpotObjects::GetBeamWidthXError
double GetBeamWidthXError() const
get average transverse beam width error ASSUME the same for X and Y
Definition: BeamSpotObjects.h:93
BeamSpotObjects::GetSigmaZError
double GetSigmaZError() const
get sigma Z, RMS bunch length Error
Definition: BeamSpotObjects.h:91
edm::LogInfo
Log< level::Info, false > LogInfo
Definition: MessageLogger.h:125
BeamSpotObjects::GetX
double GetX() const
get X beam position
Definition: BeamSpotObjects.h:67
BeamSpotObjects::GetXError
double GetXError() const
get X beam position Error
Definition: BeamSpotObjects.h:85
BeamSpotDipServer::qualities
const char * qualities[3]
Definition: BeamSpotDipServer.h:62
edm::LogWarning
Log< level::Warning, false > LogWarning
Definition: MessageLogger.h:122
BeamSpotObjects::GetZError
double GetZError() const
get Z beam position Error
Definition: BeamSpotObjects.h:89
BeamSpotOnlineObjects::GetEndTimeStamp
cond::Time_t GetEndTimeStamp() const
Definition: BeamSpotOnlineObjects.cc:92
bool BeamSpotDipServer::readRcd ( std::ifstream &  file)
private
string BeamSpotDipServer::tkStatus ( )
private

Definition at line 275 of file BeamSpotDipServer.cc.

References alignCSCRings::e, cppFunctionSkipper::exception, spr::find(), dqmPostProcessing_online::logfile, dumpparser::parse(), GlobalPosition_Frontier_DevDB_cff::record, and createJobs::tmp.

275  {
276  string outstr;
277 
278  if (readFromNFS) { // get from file on /nfs
279  ifstream logfile(sourceFile1);
280 
281  if (!logfile.good() || getFileSize(sourceFile1) == 0) {
282  // file does not exist or has zero size
283  outstr = "No CMS Tracker status available. No DAQ/DQM.";
284  } else {
285  int nthLnInRcd = 0;
286  string record;
287 
288  try {
289  string record;
290 
291  while (getline(logfile, record)) {
292  nthLnInRcd++;
293  vector<string> tmp = parse(record, " ");
294 
295  switch (nthLnInRcd) {
296  case 7:
297  if (tmp[1].find("Yes") == string::npos)
298  outstr = "CMS Tracker OFF.";
299  else
300  outstr = "CMS not taking data or no beam.";
301  break;
302  case 8:
303  runnum = stoi(tmp[1]);
304  break;
305  default:
306  break;
307  }
308  }
309  } catch (exception& e) {
310  edm::LogWarning("BeamSpotDipServer") << "exception (tkStatus): " << e.what();
311  }
312  }
313 
314  logfile.close();
315  } else {
316  // get from DCS
317  if (wholeTrackerOn)
318  outstr = "CMS not taking data or no beam.";
319  else
320  outstr = "CMS Tracker OFF.";
321  }
322 
323  return outstr;
324 }
dqmPostProcessing_online.logfile
string logfile
Definition: dqmPostProcessing_online.py:96
spr::find
void find(edm::Handle< EcalRecHitCollection > &hits, DetId thisDet, std::vector< EcalRecHitCollection::const_iterator > &hit, bool debug=false)
Definition: FindCaloHit.cc:19
BeamSpotDipServer::getFileSize
long getFileSize(std::string filename)
Definition: BeamSpotDipServer.cc:243
BeamSpotDipServer::parse
std::vector< std::string > parse(std::string line, const std::string &delimiter)
Definition: BeamSpotDipServer.cc:257
GlobalPosition_Frontier_DevDB_cff.record
tuple record
Definition: GlobalPosition_Frontier_DevDB_cff.py:10
edm::LogWarning
Log< level::Warning, false > LogWarning
Definition: MessageLogger.h:122
createJobs.tmp
tmp
align.sh
Definition: createJobs.py:716
void BeamSpotDipServer::trueRcd ( )
private

Definition at line 624 of file BeamSpotDipServer.cc.

References BeamSpotPI::dxdz, BeamSpotPI::dydz, dcs_trend_monitor_cfg::endTime, BeamSpotPI::endTimeStamp, patZpeak::events, cppFunctionSkipper::exception, BeamSpotPI::lumiRange, BeamSpotPI::meanPV, quality, BeamSpotPI::rmsPV, dcs_trend_monitor_cfg::startTime, BeamSpotPI::startTimeStamp, x, y, and z.

624  {
625  try {
626  // CMS to LHC RF
627  CMS2LHCRF_POS(x, y, z);
628 
629  Tilt[0] = dxdz * rad2urad;
630  Tilt[1] = (dydz != 0 ? (dydz * -1 * rad2urad) : 0);
631 
632  Size[0] = width_x * cm2um;
633  Size[1] = width_y * cm2um;
634  Size[2] = sigma_z * cm2mm;
635 
636  // CMS
637  messageCMS->insert(runnum, "runnum");
638  messageCMS->insert(startTime, "startTime");
639  messageCMS->insert(endTime, "endTime");
640  messageCMS->insert(startTimeStamp, "startTimeStamp");
641  messageCMS->insert(endTimeStamp, "endTimeStamp");
642  messageCMS->insert(lumiRange, "lumiRange");
643  messageCMS->insert(quality, "quality");
644  messageCMS->insert(type, "type"); // Unknown=-1, Fake=0, Tracker=2(Good)
645  messageCMS->insert(x, "x");
646  messageCMS->insert(y, "y");
647  messageCMS->insert(z, "z");
648  messageCMS->insert(dxdz, "dxdz");
649  messageCMS->insert(dydz, "dydz");
650  messageCMS->insert(width_x, "width_x");
651  messageCMS->insert(width_y, "width_y");
652  messageCMS->insert(sigma_z, "sigma_z");
653 
654  if (publishStatErrors) {
655  messageCMS->insert(err_x, "err_x");
656  messageCMS->insert(err_y, "err_y");
657  messageCMS->insert(err_z, "err_z");
658  messageCMS->insert(err_dxdz, "err_dxdz");
659  messageCMS->insert(err_dydz, "err_dydz");
660  messageCMS->insert(err_width_x, "err_width_x");
661  messageCMS->insert(err_width_y, "err_width_y");
662  messageCMS->insert(err_sigma_z, "err_sigma_z");
663  }
664 
665  // LHC
666  messageLHC->insert(Size, 3, "Size");
667  messageLHC->insert(Centroid, 3, "Centroid");
668  messageLHC->insert(Tilt, 2, "Tilt");
669 
670  // PV
671  messagePV->insert(runnum, "runnum");
672  messagePV->insert(startTime, "startTime");
673  messagePV->insert(endTime, "endTime");
674  messagePV->insert(startTimeStamp, "startTimeStamp");
675  messagePV->insert(endTimeStamp, "endTimeStamp");
676  messagePV->insert(lumiRange, "lumiRange");
677  messagePV->insert(events, "events");
678  messagePV->insert(meanPV, "meanPV");
679  messagePV->insert(err_meanPV, "err_meanPV");
680  messagePV->insert(rmsPV, "rmsPV");
681  messagePV->insert(err_rmsPV, "err_rmsPV");
682  messagePV->insert(maxPV, "maxPV");
683  messagePV->insert(nPV, "nPV");
684  } catch (exception& e) {
685  edm::LogWarning("BeamSpotDipServer") << "exception (trueRcd): " << e.what();
686  }
687 }
BeamSpotDipServer::CMS2LHCRF_POS
void CMS2LHCRF_POS(float x, float y, float z)
Definition: BeamSpotDipServer.cc:593
type
type
Definition: SiPixelVCal_PayloadInspector.cc:39
BeamSpotDipServer::publishStatErrors
const bool publishStatErrors
Definition: BeamSpotDipServer.h:63
edm::LogWarning
Log< level::Warning, false > LogWarning
Definition: MessageLogger.h:122

Member Data Documentation

std::bitset<8> BeamSpotDipServer::alive
private

Definition at line 72 of file BeamSpotDipServer.h.

edm::ESGetToken<BeamSpotOnlineObjects, BeamSpotOnlineLegacyObjectsRcd> BeamSpotDipServer::bsLegacyToken_
private

Definition at line 133 of file BeamSpotDipServer.h.

float BeamSpotDipServer::Centroid[3]
private

Definition at line 122 of file BeamSpotDipServer.h.

const int BeamSpotDipServer::cm2mm = 10
private

Definition at line 66 of file BeamSpotDipServer.h.

const int BeamSpotDipServer::cm2um = 10000
private

Definition at line 65 of file BeamSpotDipServer.h.

int BeamSpotDipServer::currentLS = 0
private

Definition at line 74 of file BeamSpotDipServer.h.

edm::InputTag BeamSpotDipServer::dcsRecordInputTag_
private

Definition at line 126 of file BeamSpotDipServer.h.

edm::EDGetTokenT<DCSRecord> BeamSpotDipServer::dcsRecordToken_
private

Definition at line 127 of file BeamSpotDipServer.h.

DipFactory* BeamSpotDipServer::dip
private

Definition at line 77 of file BeamSpotDipServer.h.

float BeamSpotDipServer::dxdz = 0
private

Definition at line 97 of file BeamSpotDipServer.h.

Referenced by BeamSpotObj.BeamSpot::Reset().

float BeamSpotDipServer::dydz = 0
private

Definition at line 98 of file BeamSpotDipServer.h.

Referenced by BeamSpotObj.BeamSpot::Reset().

std::string BeamSpotDipServer::endTime = getDateTime()
private

Definition at line 88 of file BeamSpotDipServer.h.

time_t BeamSpotDipServer::endTimeStamp = 0
private

Definition at line 90 of file BeamSpotDipServer.h.

float BeamSpotDipServer::err_dxdz = 0
private

Definition at line 102 of file BeamSpotDipServer.h.

float BeamSpotDipServer::err_dydz = 0
private

Definition at line 103 of file BeamSpotDipServer.h.

float BeamSpotDipServer::err_meanPV = 0
private

Definition at line 114 of file BeamSpotDipServer.h.

float BeamSpotDipServer::err_rmsPV = 0
private

Definition at line 116 of file BeamSpotDipServer.h.

float BeamSpotDipServer::err_sigma_z = 0
private

Definition at line 109 of file BeamSpotDipServer.h.

float BeamSpotDipServer::err_width_x = 0
private

Definition at line 107 of file BeamSpotDipServer.h.

float BeamSpotDipServer::err_width_y = 0
private

Definition at line 108 of file BeamSpotDipServer.h.

float BeamSpotDipServer::err_x = 0
private

Definition at line 99 of file BeamSpotDipServer.h.

float BeamSpotDipServer::err_y = 0
private

Definition at line 100 of file BeamSpotDipServer.h.

float BeamSpotDipServer::err_z = 0
private

Definition at line 101 of file BeamSpotDipServer.h.

int BeamSpotDipServer::events = 0
private

Definition at line 112 of file BeamSpotDipServer.h.

Referenced by eventsfwlite.Events::__getattr__(), looper.Looper::loop(), and looper.Looper::process().

const int BeamSpotDipServer::intLS = 1
private

Definition at line 67 of file BeamSpotDipServer.h.

long BeamSpotDipServer::lastFitTime = 0
private

Definition at line 70 of file BeamSpotDipServer.h.

int BeamSpotDipServer::lastlumi = -1
private

Definition at line 129 of file BeamSpotDipServer.h.

long BeamSpotDipServer::lastModTime = 0
private

Definition at line 71 of file BeamSpotDipServer.h.

int BeamSpotDipServer::lsCount = 0
private

Definition at line 73 of file BeamSpotDipServer.h.

std::string BeamSpotDipServer::lumiRange = "0 - 0"
private

Definition at line 91 of file BeamSpotDipServer.h.

int BeamSpotDipServer::maxPV = 0
private

Definition at line 117 of file BeamSpotDipServer.h.

float BeamSpotDipServer::meanPV = 0
private

Definition at line 113 of file BeamSpotDipServer.h.

DipData* BeamSpotDipServer::messageCMS
private

Definition at line 78 of file BeamSpotDipServer.h.

DipData* BeamSpotDipServer::messageLHC
private

Definition at line 79 of file BeamSpotDipServer.h.

DipData* BeamSpotDipServer::messagePV
private

Definition at line 80 of file BeamSpotDipServer.h.

int BeamSpotDipServer::nPV = 0
private

Definition at line 118 of file BeamSpotDipServer.h.

DipPublication* BeamSpotDipServer::publicationCMS
private

Definition at line 81 of file BeamSpotDipServer.h.

DipPublication* BeamSpotDipServer::publicationLHC
private

Definition at line 82 of file BeamSpotDipServer.h.

DipPublication* BeamSpotDipServer::publicationPV
private

Definition at line 83 of file BeamSpotDipServer.h.

const bool BeamSpotDipServer::publishStatErrors = true
private

Definition at line 63 of file BeamSpotDipServer.h.

const char* BeamSpotDipServer::qualities[3] = {"Uncertain", "Bad", "Good"}
private

Definition at line 62 of file BeamSpotDipServer.h.

std::string BeamSpotDipServer::quality = "Uncertain"
private

Definition at line 92 of file BeamSpotDipServer.h.

const int BeamSpotDipServer::rad2urad = 1000000
private

Definition at line 64 of file BeamSpotDipServer.h.

bool BeamSpotDipServer::readFromNFS
private

Definition at line 143 of file BeamSpotDipServer.h.

float BeamSpotDipServer::rmsPV = 0
private

Definition at line 115 of file BeamSpotDipServer.h.

int BeamSpotDipServer::runnum
private

Definition at line 86 of file BeamSpotDipServer.h.

float BeamSpotDipServer::sigma_z = 0
private

Definition at line 106 of file BeamSpotDipServer.h.

float BeamSpotDipServer::Size[3]
private

Definition at line 121 of file BeamSpotDipServer.h.

std::string BeamSpotDipServer::sourceFile
private

Definition at line 145 of file BeamSpotDipServer.h.

std::string BeamSpotDipServer::sourceFile1
private

Definition at line 146 of file BeamSpotDipServer.h.

std::string BeamSpotDipServer::startTime = getDateTime()
private

Definition at line 87 of file BeamSpotDipServer.h.

time_t BeamSpotDipServer::startTimeStamp = 0
private

Definition at line 89 of file BeamSpotDipServer.h.

std::string BeamSpotDipServer::subjectCMS
private

Definition at line 139 of file BeamSpotDipServer.h.

std::string BeamSpotDipServer::subjectLHC
private

Definition at line 140 of file BeamSpotDipServer.h.

std::string BeamSpotDipServer::subjectPV
private

Definition at line 141 of file BeamSpotDipServer.h.

bool BeamSpotDipServer::testing
private

Definition at line 137 of file BeamSpotDipServer.h.

float BeamSpotDipServer::Tilt[2]
private

Definition at line 123 of file BeamSpotDipServer.h.

std::vector<int> BeamSpotDipServer::timeoutLS
private

Definition at line 148 of file BeamSpotDipServer.h.

int BeamSpotDipServer::type = -1
private

Definition at line 93 of file BeamSpotDipServer.h.

Referenced by core.autovars.NTupleVariable::makeBranch(), DQM.DQMReader::read_objects(), and core.AutoHandle.AutoHandle::ReallyLoad().

bool BeamSpotDipServer::verbose
private

Definition at line 136 of file BeamSpotDipServer.h.

Referenced by python.diff_provenance.difference::list_diff(), python.diffProv.difference::list_diff(), python.diff_provenance.difference::module_diff(), python.diffProv.difference::module_diff(), python.diff_provenance.difference::onefilemodules(), python.diffProv.difference::onefilemodules(), core.TriggerMatchAnalyzer.TriggerMatchAnalyzer::process(), core.SkimAnalyzerCount.SkimAnalyzerCount::process(), objects.VertexAnalyzer.VertexAnalyzer::process(), and confdbOfflineConverter.OfflineConverter::query().

bool BeamSpotDipServer::wholeTrackerOn = false
private

Definition at line 130 of file BeamSpotDipServer.h.

float BeamSpotDipServer::width_x = 0
private

Definition at line 104 of file BeamSpotDipServer.h.

float BeamSpotDipServer::width_y = 0
private

Definition at line 105 of file BeamSpotDipServer.h.

float BeamSpotDipServer::x = 0
private

Definition at line 94 of file BeamSpotDipServer.h.

Referenced by python.rootplot.utilities.Hist::__init_TGraph(), svgfig.Curve.Sample::__repr__(), svgfig.Ellipse::__repr__(), edmStreamStallGrapher.Point::__str__(), python.rootplot.root2matplotlib.Hist::_prepare_xaxis(), python.rootplot.root2matplotlib.Hist::_prepare_yaxis(), python.rootplot.root2matplotlib.Hist2D::box(), python.rootplot.root2matplotlib.Hist2D::contour(), python.rootplot.root2matplotlib.Hist::errorbar(), python.rootplot.root2matplotlib.Hist::errorbarh(), geometryXMLparser.Alignable::pos(), ntupleDataFormat._HitObject::r(), ntupleDataFormat._HitObject::r3D(), and python.rootplot.utilities.Hist::TGraph().

float BeamSpotDipServer::y = 0
private

Definition at line 95 of file BeamSpotDipServer.h.

Referenced by python.rootplot.utilities.Hist::__getitem__(), python.rootplot.utilities.Hist::__init_TGraph(), python.rootplot.utilities.Hist::__iter__(), svgfig.Ellipse::__repr__(), python.rootplot.utilities.Hist::__setitem__(), edmStreamStallGrapher.Point::__str__(), python.rootplot.root2matplotlib.Hist::bar(), python.rootplot.root2matplotlib.Hist::barh(), python.rootplot.root2matplotlib.Hist2D::box(), python.rootplot.root2matplotlib.Hist2D::contour(), python.rootplot.utilities.Hist::divide_wilson(), python.rootplot.root2matplotlib.Hist::errorbar(), python.rootplot.root2matplotlib.Hist::errorbarh(), python.rootplot.root2matplotlib.Hist::hist(), python.rootplot.utilities.Hist::min(), geometryXMLparser.Alignable::pos(), ntupleDataFormat._HitObject::r(), ntupleDataFormat._HitObject::r3D(), python.rootplot.utilities.Hist::scale(), python.rootplot.utilities.Hist::TGraph(), and python.rootplot.utilities.Hist::TH1F().

float BeamSpotDipServer::z = 0
private

Definition at line 96 of file BeamSpotDipServer.h.

Referenced by geometryXMLparser.Alignable::pos(), and ntupleDataFormat._HitObject::r3D().

Generated for CMSSW Reference Manual by doxygen 1.8.5