CMS 3D CMS Logo

Namespaces | Classes | Typedefs | Enumerations | Functions
cond::persistency Namespace Reference

Namespaces

 GLOBAL_TAG
 
 GLOBAL_TAG_MAP
 
 IOV
 
 O2O_RUN
 
 PAYLOAD
 
 RUN_INFO
 
 TAG
 
 TAG_LOG
 

Classes

struct  AttributeTypeName
 
struct  AttributeTypeName< boost::posix_time::ptime >
 
struct  AttributeTypeName< cond::Binary >
 
struct  AttributeTypeName< cond::SynchronizationType >
 
struct  AttributeTypeName< cond::TimeType >
 
class  BasePayloadProxy
 
class  BulkDeleter
 
class  BulkInserter
 
class  CondDBTransaction
 
class  CondGetter
 
class  ConditionBuffer
 
class  ConnectionPool
 
class  CoralMsgReporter
 
struct  DefineQueryOutput
 
struct  DefineQueryOutput< boost::posix_time::ptime >
 
struct  DefineQueryOutput< cond::Binary >
 
struct  DefineQueryOutput< cond::SynchronizationType >
 
struct  DefineQueryOutput< cond::TimeType >
 
struct  DefineQueryOutput< std::array< char, n > >
 
class  DeleteBuffer
 
class  EchoedLogStream
 
class  EchoedLogStream< edm::LogDebug_ >
 
class  Exception
 Base exception class for the object to relational access. More...
 
struct  GetFromRow
 
struct  GetFromRow< boost::posix_time::ptime >
 
struct  GetFromRow< cond::Binary >
 
struct  GetFromRow< cond::SynchronizationType >
 
struct  GetFromRow< cond::TimeType >
 
struct  GetFromRow< std::array< char, n > >
 
class  GTEditor
 
class  GTEditorData
 
class  GTProxy
 
class  GTProxyData
 
class  GTSchema
 
class  IGTMapTable
 
class  IGTSchema
 
class  IGTTable
 
class  IIOVSchema
 
class  IIOVTable
 
class  IOVArray
 
struct  IOVComp
 
class  IOVEditor
 
class  IOVEditorData
 
class  IOVProxy
 
class  IOVProxyData
 
struct  IOVRunComp
 
class  IOVSchema
 
struct  IOVTimeComp
 
class  IPayloadMigrationTable
 
class  IPayloadTable
 
class  IRunInfoSchema
 
class  IRunInfoTable
 
class  ITagLogTable
 
class  ITagMigrationTable
 
class  ITagTable
 
class  ITransaction
 
class  KeyList
 
class  Logger
 
class  PayloadProxy
 
class  PayloadProxy< cond::persistency::KeyList >
 
class  PayloadReader
 
class  Query
 
class  QueryIterator
 
class  RowBuffer
 
class  RunInfoEditor
 
class  RunInfoEditorData
 
class  RunInfoProxy
 
class  RunInfoProxyData
 
class  RunInfoSchema
 
class  Session
 
class  SessionImpl
 
class  TableDescription
 
class  Transaction
 
class  TransactionScope
 
class  UpdateBuffer
 

Typedefs

typedef std::vector< std::tuple< cond::Time_t, cond::Hash > > IOVContainer
 

Enumerations

enum  DbAuthenticationSystem { UndefinedAuthentication = 0, CondDbKey, CoralXMLFile }
 

Functions

std::string convertoToOracleConnection (const std::string &input)
 
bool copyIov (Session &session, const std::string &sourceTag, const std::string &destTag, cond::Time_t souceSince, cond::Time_t destSince, const std::string &description)
 
unsigned int countslash (const std::string &input)
 
template<>
void f_add_attribute (coral::AttributeList &data, const std::string &attributeName, const boost::posix_time::ptime &param, bool init)
 
template<>
void f_add_attribute (coral::AttributeList &data, const std::string &attributeName, const cond::Binary &param, bool init)
 
template<>
void f_add_attribute (coral::AttributeList &data, const std::string &attributeName, const cond::SynchronizationType &param, bool init)
 
template<>
void f_add_attribute (coral::AttributeList &data, const std::string &attributeName, const cond::TimeType &param, bool init)
 
template<typename T >
void f_add_attribute (coral::AttributeList &data, const std::string &attributeName, const T &param, bool init=true)
 
template<typename Column , typename P >
void f_add_column_data (coral::AttributeList &data, const P &param, bool init=true)
 
template<typename T >
void f_add_column_description (coral::TableDescription &table, const std::string &columnName, size_t size=0, bool notNull=true)
 
template<typename C1 , typename C2 >
void f_add_condition (std::string &whereClause, const std::string condition="=")
 
template<typename Column , typename P >
void f_add_condition_data (coral::AttributeList &data, std::string &whereClause, const P &value, const std::string condition="=")
 
std::pair< std::string, std::shared_ptr< void > > fetch (const cond::Hash &payloadId, Session &session)
 
std::pair< std::string, std::shared_ptr< void > > fetchIfExists (const cond::Hash &payloadId, Session &session, bool &exists)
 
std::pair< std::string, std::shared_ptr< void > > fetchOne (const std::string &payloadTypeName, const cond::Binary &data, const cond::Binary &streamerInfo, std::shared_ptr< void > payloadPtr)
 
std::string fullyQualifiedTag (const std::string &tag, const std::string &connectionString)
 
std::string get_timestamp ()
 
std::string get_timestamp_for_filename ()
 
std::pair< std::string, std::string > getConnectionParams (const std::string &connectionString, const std::string &transactionId, const std::string &signature)
 
std::string getConnectionProtocol (const std::string &connectionString)
 
cond::Hash import (Session &source, const cond::Hash &sourcePayloadId, const std::string &inputTypeName, const void *inputPtr, Session &destination)
 
size_t importIovs (const std::string &sourceTag, Session &sourceSession, const std::string &destTag, Session &destSession, cond::Time_t begin, cond::Time_t end, const std::string &description, const std::string &editingNote, bool override, bool serialize, bool forceInsert)
 
cond::Hash importPayload (Session &sourceSession, const cond::Hash &sourcePayloadId, Session &destSession, bool reserialize)
 
bool iovSorter (const std::tuple< cond::Time_t, cond::Hash, boost::posix_time::ptime > &f, const std::tuple< cond::Time_t, cond::Hash, boost::posix_time::ptime > &s)
 
template<typename T , typename Arg1 >
constexpr bool is_same_any ()
 
template<typename T , typename Arg1 , typename Arg2 , typename... Args>
constexpr bool is_same_any ()
 
cond::Hash makeHash (const std::string &objectType, const cond::Binary &data)
 
std::tuple< std::string, std::string, std::string > parseConnectionString (const std::string &connectionString)
 
std::string parseFipConnectionString (const std::string &fipConnect)
 
std::pair< std::string, std::string > parseTag (const std::string &tag)
 
std::string print_timestamp (const boost::posix_time::ptime &t, const char *format_s="%Y-%m-%d %H:%M:%S.%f")
 
template<typename T >
std::vector< T >::const_iterator search (const cond::Time_t &val, const std::vector< T > &container)
 
template<>
cond::Hash Session::storePayload< std::string > (const std::string &payload, const boost::posix_time::ptime &creationTime)
 
void setTillToLastIov (cond::Iov_t &target, cond::Time_t endOfValidity)
 
template<typename T , typename P >
void static_assert_is_same_decayed ()
 
void throwException (const std::string &message, const std::string &methodName)
 

Typedef Documentation

◆ IOVContainer

typedef std::vector<std::tuple<cond::Time_t, cond::Hash> > cond::persistency::IOVContainer

Definition at line 25 of file IOVProxy.h.

Enumeration Type Documentation

◆ DbAuthenticationSystem

Enumerator
UndefinedAuthentication 
CondDbKey 
CoralXMLFile 

Definition at line 32 of file ConnectionPool.h.

Function Documentation

◆ convertoToOracleConnection()

std::string cond::persistency::convertoToOracleConnection ( const std::string &  input)
inline

Definition at line 121 of file Utils.h.

121  {
122  // leave the connection string unmodified for sqlite
123  if (input.find("sqlite") == 0 || input.find("oracle") == 0)
124  return input;
125 
126  //static const boost::regex trivial("oracle://(cms_orcon_adg|cms_orcoff_prep)/([_[:alnum:]]+?)");
127  static const boost::regex short_frontier("frontier://([[:alnum:]]+?)/([_[:alnum:]]+?)");
128  static const boost::regex long_frontier("frontier://((\\([-[:alnum:]]+?=[^\\)]+?\\))+)/([_[:alnum:]]+?)");
129  static const boost::regex long_frontier_serverurl("\\(serverurl=[^\\)]+?/([[:alnum:]]+?)\\)");
130 
131  static const std::map<std::string, std::string> frontierMap = {
132  {"PromptProd", "cms_orcon_adg"},
133  {"FrontierProd", "cms_orcon_adg"},
134  {"FrontierArc", "cms_orcon_adg"},
135  {"FrontierOnProd", "cms_orcon_adg"},
136  {"FrontierPrep", "cms_orcoff_prep"},
137  };
138 
139  boost::smatch matches;
140 
141  static const std::string technology("oracle://");
142  std::string service("");
143  std::string account("");
144 
145  bool match = false;
146  if (boost::regex_match(input, matches, short_frontier)) {
147  service = matches[1];
148  account = matches[2];
149  match = true;
150  }
151 
152  if (boost::regex_match(input, matches, long_frontier)) {
153  std::string frontier_config(matches[1]);
154  boost::smatch matches2;
155  if (not boost::regex_search(frontier_config, matches2, long_frontier_serverurl))
156  throwException("No serverurl in matched long frontier", "convertoToOracleConnection");
157  service = matches2[1];
158  account = matches[3];
159  match = true;
160  }
161 
162  if (!match)
163  throwException("Connection string " + input + " can't be converted to oracle connection.",
164  "convertoToOracleConnection");
165 
166  if (service == "FrontierArc") {
167  size_t len = account.size() - 5;
168  account = account.substr(0, len);
169  }
170 
171  auto it = frontierMap.find(service);
172  if (it == frontierMap.end())
173  throwException("Connection string can't be converted.", "convertoToOracleConnection");
174  service = it->second;
175 
176  return technology + service + "/" + account;
177  }

References input, match(), patCandidatesForDimuonsSequences_cff::matches, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

Referenced by CondDBESSource::CondDBESSource().

◆ copyIov()

bool cond::persistency::copyIov ( Session session,
const std::string &  sourceTag,
const std::string &  destTag,
cond::Time_t  souceSince,
cond::Time_t  destSince,
const std::string &  description 
)

Definition at line 167 of file CondDBTools.cc.

172  {
173  persistency::TransactionScope ssc(session.transaction());
174  ssc.start(false);
175  std::cout << " Loading source iov..." << std::endl;
176  persistency::IOVProxy p = session.readIov(sourceTag);
177  auto iovs = p.selectAll();
178  if (iovs.size() == 0) {
179  std::cout << " Tag contains 0 iovs." << std::endl;
180  return false;
181  } else {
182  std::cout << " Iov size:" << iovs.size() << " timeType:" << p.tagInfo().timeType << " payloadObjectType=\""
183  << p.tagInfo().payloadType << "\"" << std::endl;
184  }
185 
186  auto iiov = iovs.find(sourceSince);
187  if (iiov == iovs.end()) {
188  std::cout << "ERROR: No Iov valid found for target time " << sourceSince << std::endl;
189  return false;
190  }
191 
192  persistency::IOVEditor editor;
193  if (session.existsIov(destTag)) {
194  if (!description.empty())
195  std::cout << " INFO. Destination Tag " << destTag
196  << " already exists. Provided description will be ignored." << std::endl;
197  editor = session.editIov(destTag);
198  if (editor.timeType() != p.tagInfo().timeType)
199  throwException("TimeType of the destination tag does not match with the source tag timeType.", "importIovs");
200  if (editor.payloadType() != p.tagInfo().payloadType)
201  throwException("PayloadType of the destination tag does not match with the source tag payloadType.",
202  "importIovs");
203  } else {
204  editor =
205  session.createIov(p.tagInfo().payloadType, destTag, p.tagInfo().timeType, p.tagInfo().synchronizationType);
206  if (description.empty())
207  editor.setDescription("Created copying iovs from tag " + sourceTag);
208  else
209  editor.setDescription(description);
210  }
211 
212  editor.insert(destSince, (*iiov).payloadId);
213 
214  std::cout << " Flushing changes..." << std::endl;
215  editor.flush();
216  ssc.commit();
217  return true;
218  }

References gather_cfg::cout, cond::persistency::Session::createIov(), edmLumisInFiles::description, cond::persistency::Session::editIov(), cond::persistency::Session::existsIov(), cond::persistency::IOVEditor::flush(), cond::persistency::IOVEditor::insert(), AlCaHLTBitMon_ParallelJobs::p, cond::persistency::IOVEditor::payloadType(), cond::persistency::Session::readIov(), cond::persistency::IOVEditor::setDescription(), RawToDigi_cff::sourceTag, cond::persistency::TransactionScope::start(), throwException(), cond::persistency::IOVEditor::timeType(), and cond::persistency::Session::transaction().

◆ countslash()

unsigned int cond::persistency::countslash ( const std::string &  input)

Definition at line 13 of file DbConnectionString.cc.

13  {
14  unsigned int count = 0;
15  std::string::size_type slashpos(0);
16  while (slashpos != std::string::npos) {
17  slashpos = input.find('/', slashpos);
18  if (slashpos != std::string::npos) {
19  ++count;
20  // start next search after this word
21  slashpos += 1;
22  }
23  }
24  return count;
25  }

References KineDebug3::count(), and input.

Referenced by getConnectionParams().

◆ f_add_attribute() [1/5]

template<>
void cond::persistency::f_add_attribute ( coral::AttributeList &  data,
const std::string &  attributeName,
const boost::posix_time::ptime &  param,
bool  init 
)
inline

Definition at line 110 of file DbCore.h.

113  {
114  if (init)
115  data.extend<coral::TimeStamp>(attributeName);
116  data[attributeName].data<coral::TimeStamp>() = coral::TimeStamp(param);
117  }

References data.

◆ f_add_attribute() [2/5]

template<>
void cond::persistency::f_add_attribute ( coral::AttributeList &  data,
const std::string &  attributeName,
const cond::Binary param,
bool  init 
)
inline

Definition at line 100 of file DbCore.h.

103  {
104  if (init)
105  data.extend<coral::Blob>(attributeName);
106  data[attributeName].bind(param.get());
107  }

References data, and cond::Binary::get().

◆ f_add_attribute() [3/5]

template<>
void cond::persistency::f_add_attribute ( coral::AttributeList &  data,
const std::string &  attributeName,
const cond::SynchronizationType param,
bool  init 
)
inline

Definition at line 130 of file DbCore.h.

133  {
134  if (init)
135  data.extend<std::string>(attributeName);
136  data[attributeName].data<std::string>() = synchronizationTypeNames(param);
137  }

References data, AlCaHLTBitMon_QueryRunRegistry::string, and cond::synchronizationTypeNames().

◆ f_add_attribute() [4/5]

template<>
void cond::persistency::f_add_attribute ( coral::AttributeList &  data,
const std::string &  attributeName,
const cond::TimeType param,
bool  init 
)
inline

Definition at line 120 of file DbCore.h.

123  {
124  if (init)
125  data.extend<std::string>(attributeName);
126  data[attributeName].data<std::string>() = cond::time::timeTypeName(param);
127  }

References data, AlCaHLTBitMon_QueryRunRegistry::string, and cond::time::timeTypeName().

◆ f_add_attribute() [5/5]

template<typename T >
void cond::persistency::f_add_attribute ( coral::AttributeList &  data,
const std::string &  attributeName,
const T param,
bool  init = true 
)
inline

Definition at line 90 of file DbCore.h.

93  {
94  if (init)
95  data.extend<T>(attributeName);
96  data[attributeName].data<T>() = param;
97  }

References data.

Referenced by f_add_column_data(), and f_add_condition_data().

◆ f_add_column_data()

template<typename Column , typename P >
void cond::persistency::f_add_column_data ( coral::AttributeList &  data,
const P param,
bool  init = true 
)
inline

Definition at line 141 of file DbCore.h.

141  {
142  static_assert_is_same_decayed<typename Column::type, P>();
144  }

References data, f_add_attribute(), and Skims_PA_cff::name.

◆ f_add_column_description()

template<typename T >
void cond::persistency::f_add_column_description ( coral::TableDescription &  table,
const std::string &  columnName,
size_t  size = 0,
bool  notNull = true 
)

Definition at line 265 of file DbCore.h.

268  {
269  table.insertColumn(columnName, AttributeTypeName<T>()(), size);
270  if (notNull)
271  table.setNotNullConstraint(columnName);
272  }

References findQualityFiles::size, and TableParser::table.

◆ f_add_condition()

template<typename C1 , typename C2 >
void cond::persistency::f_add_condition ( std::string &  whereClause,
const std::string  condition = "=" 
)
inline

Definition at line 165 of file DbCore.h.

165  {
166  if (!whereClause.empty())
167  whereClause += " AND ";
168  whereClause += C1::fullyQualifiedName() + " " + condition + " " + C2::fullyQualifiedName() + " ";
169  }

References goodZToMuMu_cfi::condition.

◆ f_add_condition_data()

template<typename Column , typename P >
void cond::persistency::f_add_condition_data ( coral::AttributeList &  data,
std::string &  whereClause,
const P value,
const std::string  condition = "=" 
)
inline

Definition at line 148 of file DbCore.h.

151  {
152  static_assert_is_same_decayed<typename Column::type, P>();
153  std::stringstream varId;
154  unsigned int id = data.size();
155  varId << Column::name << "_" << id;
156  if (!whereClause.empty())
157  whereClause += " AND ";
158  whereClause += Column::fullyQualifiedName() + " " + condition + " :" + varId.str() + " ";
159  //bool init = (id == 0);
160  f_add_attribute(data, varId.str(), value);
161  }

References goodZToMuMu_cfi::condition, data, f_add_attribute(), triggerObjects_cff::id, Skims_PA_cff::name, and relativeConstraints::value.

◆ fetch()

std::pair< std::string, std::shared_ptr< void > > cond::persistency::fetch ( const cond::Hash payloadId,
Session session 
)

Definition at line 337 of file CondDBFetch.cc.

337  {
338  std::shared_ptr<void> payloadPtr;
340  cond::Binary streamerInfo;
341  std::string payloadTypeName;
342  bool found = session.fetchPayloadData(payloadId, payloadTypeName, data, streamerInfo);
343  if (!found)
345  "Payload with id " + boost::lexical_cast<std::string>(payloadId) + " has not been found in the database.",
346  "fetch");
347  return fetchOne(payloadTypeName, data, streamerInfo, payloadPtr);
348  }

References data, fetchOne(), cond::persistency::Session::fetchPayloadData(), newFWLiteAna::found, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

Referenced by LMFDat::fetch(), l1tpf_calo::SimpleCaloLinkerBase::fetch(), and importPayload().

◆ fetchIfExists()

std::pair<std::string, std::shared_ptr<void> > cond::persistency::fetchIfExists ( const cond::Hash payloadId,
Session session,
bool &  exists 
)

Definition at line 25 of file CondDBImport.cc.

27  {
28  std::shared_ptr<void> payloadPtr;
30  cond::Binary streamerInfo;
31  std::string payloadTypeName;
32  exists = session.fetchPayloadData(payloadId, payloadTypeName, data, streamerInfo);
33  if (exists) {
34  return fetchOne(payloadTypeName, data, streamerInfo, payloadPtr);
35  } else
36  return std::make_pair(std::string(""), std::shared_ptr<void>());
37  }

References data, fetchOne(), cond::persistency::Session::fetchPayloadData(), and AlCaHLTBitMon_QueryRunRegistry::string.

◆ fetchOne()

std::pair< std::string, std::shared_ptr< void > > cond::persistency::fetchOne ( const std::string &  payloadTypeName,
const cond::Binary data,
const cond::Binary streamerInfo,
std::shared_ptr< void >  payloadPtr 
)

Definition at line 23 of file CondDBFetch.cc.

26  {
27  bool match = false;
29  FETCH_PAYLOAD_CASE(std::vector<unsigned long long>)
248  //FETCH_PAYLOAD_CASE( PerformancePayload )
315 
316  //
317  if (payloadTypeName == "PhysicsTools::Calibration::Histogram3D<double,double,double,double>") {
318  payloadPtr = deserialize<PhysicsTools::Calibration::Histogram3D<double, double, double, double> >(
319  payloadTypeName, data, streamerInfo);
320  match = true;
321  }
322  if (payloadTypeName == "PhysicsTools::Calibration::Histogram2D<double,double,double>") {
323  payloadPtr = deserialize<PhysicsTools::Calibration::Histogram2D<double, double, double> >(
324  payloadTypeName, data, streamerInfo);
325  match = true;
326  }
327  if (payloadTypeName == "std::vector<unsignedlonglong,std::allocator<unsignedlonglong>>") {
328  payloadPtr = deserialize<std::vector<unsigned long long> >(payloadTypeName, data, streamerInfo);
329  match = true;
330  }
331 
332  if (!match)
333  throwException("Payload type \"" + payloadTypeName + "\" is unknown.", "fetch");
334  return std::make_pair(payloadTypeName, payloadPtr);
335  }

References data, FETCH_PAYLOAD_CASE, match(), AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

Referenced by fetch(), and fetchIfExists().

◆ fullyQualifiedTag()

std::string cond::persistency::fullyQualifiedTag ( const std::string &  tag,
const std::string &  connectionString 
)

Definition at line 8 of file GTProxy.cc.

8  {
9  if (connectionString.empty())
10  return tag;
11  return tag + "@[" + connectionString + "]";
12  }

References l1RCTOmdsFedVectorProducer_cfi::connectionString, and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by CondDBESSource::CondDBESSource().

◆ get_timestamp()

std::string cond::persistency::get_timestamp ( )

Definition at line 95 of file Logger.cc.

95  {
96  auto now = boost::posix_time::microsec_clock::universal_time();
97  return print_timestamp(now);
98  }

References fileCollector::now, and print_timestamp().

Referenced by cond::persistency::Logger::log().

◆ get_timestamp_for_filename()

std::string cond::persistency::get_timestamp_for_filename ( )

Definition at line 99 of file Logger.cc.

99  {
100  auto now = boost::posix_time::microsec_clock::universal_time();
101  return print_timestamp(now, "%Y-%m-%d_%H-%M-%S");
102  }

References fileCollector::now, and print_timestamp().

Referenced by cond::persistency::Logger::saveOnFile().

◆ getConnectionParams()

std::pair< std::string, std::string > cond::persistency::getConnectionParams ( const std::string &  connectionString,
const std::string &  transactionId,
const std::string &  signature 
)

Definition at line 39 of file DbConnectionString.cc.

41  {
42  if (connectionString.empty())
43  cond::throwException("The connection string is empty.", "getConnectionParams");
45  std::string finalConn = connectionString;
46  std::string refreshConn("");
47  if (protocol == "frontier") {
48  std::string protocol("frontier://");
49  std::string::size_type fpos = connectionString.find(protocol);
50  unsigned int nslash = countslash(connectionString.substr(protocol.size(), connectionString.size() - fpos));
51  if (nslash == 1) {
52  edm::Service<edm::SiteLocalConfig> localconfservice;
53  if (!localconfservice.isAvailable()) {
54  cond::throwException("edm::SiteLocalConfigService is not available", "getConnectionParams");
55  }
56  finalConn = localconfservice->lookupCalibConnect(connectionString);
57  }
58  if (!transactionId.empty()) {
59  size_t l = finalConn.rfind('/');
60  finalConn.insert(l, "(freshkey=" + transactionId + ')');
61  }
62 
63  //When the signature parameter is set to sig, FroNTier requests that the server sends digital signatures on every response.
64  //We test here that the signature string, if defined, is actually set to sig, otherwise we throw an exception
65  std::string signatureParameter("sig");
66  if (!signature.empty()) {
67  if (signature == signatureParameter) {
68  std::string::size_type s = finalConn.rfind('/');
69  finalConn.insert(s, "(security=" + signature + ')');
70  } else {
71  cond::throwException("The FroNTier security option is invalid.", "getConnectionParams");
72  }
73  }
74 
75  std::string::size_type startRefresh = finalConn.find("://");
76  if (startRefresh != std::string::npos) {
77  startRefresh += 3;
78  }
79  std::string::size_type endRefresh = finalConn.rfind("/", std::string::npos);
80  if (endRefresh == std::string::npos) {
81  refreshConn = finalConn;
82  } else {
83  refreshConn = finalConn.substr(startRefresh, endRefresh - startRefresh);
84  if (refreshConn.substr(0, 1) != "(") {
85  //if the connect string is not a complicated parenthesized string,
86  // an http:// needs to be at the beginning of it
87  refreshConn.insert(0, "http://");
88  }
89  }
90  } else if (protocol == "sqlite_fip") {
92  }
93  return std::make_pair(finalConn, refreshConn);
94  }

References l1RCTOmdsFedVectorProducer_cfi::connectionString, countslash(), getConnectionProtocol(), edm::Service< T >::isAvailable(), cmsLHEtoEOSManager::l, edm::SiteLocalConfig::lookupCalibConnect(), parseFipConnectionString(), alignCSCRings::s, signature, AlCaHLTBitMon_QueryRunRegistry::string, and cond::throwException().

Referenced by cond::persistency::ConnectionPool::createCoralSession().

◆ getConnectionProtocol()

std::string cond::persistency::getConnectionProtocol ( const std::string &  connectionString)
inline

Definition at line 87 of file Utils.h.

87  {
88  size_t techEnd = connectionString.find(':');
89  if (techEnd == std::string::npos)
90  throwException("Could not resolve the connection protocol on " + connectionString + ".",
91  "getConnectionProtocol");
92  std::string technology = connectionString.substr(0, techEnd);
93  return technology;
94  }

References l1RCTOmdsFedVectorProducer_cfi::connectionString, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

Referenced by getConnectionParams(), and parseConnectionString().

◆ import()

cond::Hash cond::persistency::import ( Session source,
const cond::Hash sourcePayloadId,
const std::string &  inputTypeName,
const void *  inputPtr,
Session destination 
)

Definition at line 39 of file CondDBImport.cc.

43  {
44  cond::Hash payloadId("");
45  bool newInsert = false;
46  bool match = false;
47  if (inputPtr) {
49  IMPORT_PAYLOAD_CASE(std::vector<unsigned long long>)
252  if (inputTypeName == "L1TriggerKeyList") {
253  match = true;
254  throwException("Import of \"L1TriggerKeyList\" type payloads is not supported.", "import");
255  }
256  //IMPORT_PAYLOAD_CASE( L1TriggerKeyList )
271  //IMPORT_PAYLOAD_CASE( PerformancePayload )
340  if (inputTypeName == "PhysicsTools::Calibration::Histogram3D<double,double,double,double>") {
341  match = true;
344  payloadId = destination.storePayload(obj, boost::posix_time::microsec_clock::universal_time());
345  }
346  if (inputTypeName == "PhysicsTools::Calibration::Histogram2D<double,double,double>") {
347  match = true;
350  payloadId = destination.storePayload(obj, boost::posix_time::microsec_clock::universal_time());
351  }
352  if (inputTypeName == "std::vector<unsignedlonglong,std::allocator<unsignedlonglong>>") {
353  match = true;
354  const std::vector<unsigned long long>& obj = *static_cast<const std::vector<unsigned long long>*>(inputPtr);
355  payloadId = destination.storePayload(obj, boost::posix_time::microsec_clock::universal_time());
356  }
357 
358  if (!match)
359  throwException("Payload type \"" + inputTypeName + "\" is unknown.", "import");
360  }
361  return payloadId;
362  }

References HLTMuonOfflineAnalyzer_cff::destination, IMPORT_PAYLOAD_CASE, match(), getGTfromDQMFile::obj, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

Referenced by edm::python3::initializePyBind11Module(), edm::python::initializePyBind11Module(), PyBind11ProcessDesc::prepareToRead(), cmspython3::PyBind11ProcessDesc::prepareToRead(), edm::cmspybind11_p3::readPSetsFrom(), and edm::cmspybind11::readPSetsFrom().

◆ importIovs()

size_t cond::persistency::importIovs ( const std::string &  sourceTag,
Session sourceSession,
const std::string &  destTag,
Session destSession,
cond::Time_t  begin,
cond::Time_t  end,
const std::string &  description,
const std::string &  editingNote,
bool  override,
bool  serialize,
bool  forceInsert 
)

Definition at line 43 of file CondDBTools.cc.

53  {
54  persistency::TransactionScope ssc(sourceSession.transaction());
55  ssc.start();
56  std::cout << " Loading source iov..." << std::endl;
57  persistency::IOVProxy p = sourceSession.readIov(sourceTag);
58  auto iovs = p.selectAll();
59  if (iovs.size() == 0) {
60  std::cout << " Tag contains 0 iovs." << std::endl;
61  return 0;
62  } else {
63  std::cout << " Iov size:" << iovs.size() << " timeType:" << p.tagInfo().timeType << " payloadObjectType=\""
64  << p.tagInfo().payloadType << "\"" << std::endl;
65  }
66  if ((*iovs.begin()).since > begin)
67  begin = (*iovs.begin()).since;
68  if (end < begin) {
69  std::cout << " No Iov in the selected range." << std::endl;
70  return 0;
71  }
72  persistency::IOVEditor editor;
73  persistency::TransactionScope dsc(destSession.transaction());
74  dsc.start(false);
75  bool exists = false;
76  if (!destSession.existsDatabase()) {
77  destSession.createDatabase();
78  } else {
79  exists = destSession.existsIov(destTag);
80  }
81  persistency::IOVProxy dp;
82  if (exists) {
83  dp = destSession.readIov(destTag);
84  editor = destSession.editIov(destTag);
85  if (!description.empty())
86  std::cout << " INFO. Destination Tag " << destTag
87  << " already exists. Provided description will be ignored." << std::endl;
88  if (editor.timeType() != p.tagInfo().timeType)
89  throwException("TimeType of the destination tag does not match with the source tag timeType.", "importIovs");
90  if (editor.payloadType() != p.tagInfo().payloadType)
91  throwException("PayloadType of the destination tag does not match with the source tag payloadType.",
92  "importIovs");
93  } else {
94  editor = destSession.createIov(
95  p.tagInfo().payloadType, destTag, p.tagInfo().timeType, p.tagInfo().synchronizationType);
96  if (description.empty())
97  editor.setDescription("Created copying tag " + sourceTag + " from " + sourceSession.connectionString());
98  else
99  editor.setDescription(description);
100  }
101  size_t niovs = 0;
102  std::set<cond::Hash> pids;
103  std::set<cond::Time_t> sinces;
104  auto iiov = iovs.find(begin);
105  cond::Time_t newSince = begin;
106  while (iiov != iovs.end()) {
107  // skip duplicated sinces
108  if (sinces.find(newSince) != sinces.end()) {
109  std::cout << " WARNING. Skipping duplicated since=" << newSince << std::endl;
110  continue;
111  }
112  // make sure that we import the payload _IN_USE_
113  auto usedIov = p.getInterval(newSince);
114  cond::Hash ph = importPayload(sourceSession, usedIov.payloadId, destSession, reserialize);
115  pids.insert(ph);
116  bool skip = false;
117  if (exists) {
118  // don't insert if the same entry is already there...
119  auto diovs = dp.selectAll();
120  auto ie = diovs.find(newSince);
121  if (ie != diovs.end()) {
122  if (((*ie).since == newSince) && ((*ie).payloadId == usedIov.payloadId)) {
123  skip = true;
124  }
125  }
126  }
127  if (!skip) {
128  editor.insert(newSince, ph);
129  sinces.insert(newSince);
130  niovs++;
131  if (niovs && (niovs % 1000 == 0))
132  std::cout << " Total of iov inserted: " << niovs << " payloads: " << pids.size() << std::endl;
133  }
134  iiov++;
135  if (iiov == iovs.end() || (*iiov).since > end) {
136  break;
137  } else {
138  newSince = (*iiov).since;
139  }
140  }
141  if (exists && override) {
142  std::cout << " Adding overlying iovs..." << std::endl;
143  persistency::IOVProxy dp = destSession.readIov(destTag);
144  auto diovs = dp.selectRange(begin, end);
145  std::set<cond::Time_t> extraSinces;
146  for (auto iov : diovs) {
147  auto siov = p.getInterval(iov.since);
148  if (siov.since != iov.since) {
149  if (extraSinces.find(iov.since) == extraSinces.end()) {
150  editor.insert(iov.since, siov.payloadId);
151  extraSinces.insert(iov.since);
152  niovs++;
153  if (niovs && (niovs % 1000 == 0))
154  std::cout << " Total of iov inserted: " << niovs << " payloads: " << pids.size() << std::endl;
155  }
156  }
157  }
158  }
159  std::cout << " Total of iov inserted: " << niovs << " payloads: " << pids.size() << std::endl;
160  std::cout << " Flushing changes..." << std::endl;
161  editor.flush(editingNote, forceInsert);
162  dsc.commit();
163  ssc.commit();
164  return niovs;
165  }

References begin, cond::persistency::Session::connectionString(), gather_cfg::cout, cond::persistency::Session::createDatabase(), cond::persistency::Session::createIov(), edmLumisInFiles::description, Calorimetry_cff::dp, cond::persistency::Session::editIov(), end, cond::persistency::Session::existsDatabase(), cond::persistency::Session::existsIov(), cond::persistency::IOVEditor::flush(), importPayload(), cond::persistency::IOVEditor::insert(), AlCaHLTBitMon_ParallelJobs::p, cond::persistency::IOVEditor::payloadType(), cond::persistency::Session::readIov(), cond::persistency::IOVEditor::setDescription(), writeEcalDQMStatus::since, optionsL1T::skip, RawToDigi_cff::sourceTag, cond::persistency::TransactionScope::start(), throwException(), cond::persistency::IOVEditor::timeType(), and cond::persistency::Session::transaction().

◆ importPayload()

cond::Hash cond::persistency::importPayload ( Session sourceSession,
const cond::Hash sourcePayloadId,
Session destSession,
bool  reserialize 
)

Definition at line 16 of file CondDBTools.cc.

19  {
20  if (reserialize) {
21  std::pair<std::string, std::shared_ptr<void> > readBackPayload = fetch(sourcePayloadId, sourceSession);
22  return import(sourceSession, sourcePayloadId, readBackPayload.first, readBackPayload.second.get(), destSession);
23  } else {
25  cond::Binary payloadData;
26  cond::Binary streamerInfoData;
27  if (!sourceSession.fetchPayloadData(sourcePayloadId, payloadType, payloadData, streamerInfoData)) {
28  cond::throwException("Payload with hash" + sourcePayloadId + " has not been found in the source database.",
29  "importPayload");
30  }
31  boost::posix_time::ptime now = boost::posix_time::microsec_clock::universal_time();
32  return destSession.storePayloadData(payloadType, std::make_pair(payloadData, streamerInfoData), now);
33  }
34  }

References fetch(), cond::persistency::Session::fetchPayloadData(), fileCollector::now, HLT_2018_cff::payloadType, cond::persistency::Session::storePayloadData(), AlCaHLTBitMon_QueryRunRegistry::string, and cond::throwException().

Referenced by importIovs().

◆ iovSorter()

bool cond::persistency::iovSorter ( const std::tuple< cond::Time_t, cond::Hash, boost::posix_time::ptime > &  f,
const std::tuple< cond::Time_t, cond::Hash, boost::posix_time::ptime > &  s 
)

Definition at line 160 of file IOVEditor.cc.

161  {
162  return std::get<0>(f) < std::get<0>(s);
163  }

References f, and alignCSCRings::s.

Referenced by cond::persistency::IOVEditor::flush().

◆ is_same_any() [1/2]

template<typename T , typename Arg1 >
constexpr bool cond::persistency::is_same_any ( )
constexpr

Definition at line 275 of file DbCore.h.

275  {
277  };

References relativeConstraints::value.

Referenced by is_same_any().

◆ is_same_any() [2/2]

template<typename T , typename Arg1 , typename Arg2 , typename... Args>
constexpr bool cond::persistency::is_same_any ( )
constexpr

Definition at line 280 of file DbCore.h.

280  {
281  return is_same_any<T, Arg1>() || is_same_any<T, Arg2, Args...>();
282  };

References is_same_any().

◆ makeHash()

cond::Hash cond::persistency::makeHash ( const std::string &  objectType,
const cond::Binary data 
)

Definition at line 10 of file IOVSchema.cc.

10  {
11  SHA_CTX ctx;
12  if (!SHA1_Init(&ctx)) {
13  throwException("SHA1 initialization error.", "IOVSchema::makeHash");
14  }
15  if (!SHA1_Update(&ctx, objectType.c_str(), objectType.size())) {
16  throwException("SHA1 processing error (1).", "IOVSchema::makeHash");
17  }
18  if (!SHA1_Update(&ctx, data.data(), data.size())) {
19  throwException("SHA1 processing error (2).", "IOVSchema::makeHash");
20  }
21  unsigned char hash[SHA_DIGEST_LENGTH];
22  if (!SHA1_Final(hash, &ctx)) {
23  throwException("SHA1 finalization error.", "IOVSchema::makeHash");
24  }
25 
26  char tmp[SHA_DIGEST_LENGTH * 2 + 1];
27  // re-write bytes in hex
28  for (unsigned int i = 0; i < 20; i++) {
29  ::sprintf(&tmp[i * 2], "%02x", hash[i]);
30  }
31  tmp[20 * 2] = 0;
32  return tmp;
33  }

References data, cond::hash, mps_fire::i, throwException(), and createJobs::tmp.

Referenced by cond::persistency::PAYLOAD::Table::insertIfNew().

◆ parseConnectionString()

std::tuple<std::string, std::string, std::string> cond::persistency::parseConnectionString ( const std::string &  connectionString)
inline

Definition at line 96 of file Utils.h.

96  {
99  std::string databaseName("");
100  if (protocol == "sqlite" || protocol == "sqlite_file" || protocol == "sqlite_fip") {
101  databaseName = connectionString.substr(protocol.size() + 1);
102  } else if (protocol == "oracle" || protocol == "frontier") {
103  size_t ptr = protocol.size() + 1;
104  if (connectionString.substr(ptr, 2) != "//")
106  "Connection string " + connectionString + " is invalid format for technology \"" + protocol + "\".",
107  "parseConnectionString");
108  ptr += 2;
109  size_t serviceEnd = connectionString.find('/', ptr);
110  if (serviceEnd == std::string::npos)
111  throwException("Connection string " + connectionString + " is invalid.", "parseConnectionString");
112  serviceName = connectionString.substr(ptr, serviceEnd - ptr);
113  ptr = serviceEnd + 1;
114  databaseName = connectionString.substr(ptr);
115  } else
116  throwException("Technology " + protocol + " is not known.", "parseConnectionString");
117 
118  return std::make_tuple(protocol, serviceName, databaseName);
119  }

References l1RCTOmdsFedVectorProducer_cfi::connectionString, getConnectionProtocol(), serviceName, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

Referenced by CondDBESSource::CondDBESSource(), and CondDBESSource::fillTagCollectionFromGT().

◆ parseFipConnectionString()

std::string cond::persistency::parseFipConnectionString ( const std::string &  fipConnect)

Definition at line 27 of file DbConnectionString.cc.

27  {
28  std::string connect("sqlite_file:");
29  std::string::size_type pos = fipConnect.find(':');
30  std::string fipLocation = fipConnect.substr(pos + 1);
31  edm::FileInPath fip(fipLocation);
32  connect.append(fip.fullPath());
33  return connect;
34  }

References DBConfiguration_cff::connect, edm::FileInPath::fullPath(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by getConnectionParams().

◆ parseTag()

std::pair< std::string, std::string > cond::persistency::parseTag ( const std::string &  tag)

Definition at line 14 of file GTProxy.cc.

14  {
15  std::string pfn("");
16  std::string t(tag);
17  size_t pos = tag.rfind("[");
18  if (pos != std::string::npos && tag.size() >= pos + 2) {
19  if (tag[pos - 1] == '@' && tag[tag.size() - 1] == ']') {
20  pfn = tag.substr(pos + 1, tag.size() - pos - 2);
21  t = tag.substr(0, pos - 1);
22  }
23  }
24  return std::make_pair(t, pfn);
25  }

References AlCaHLTBitMon_QueryRunRegistry::string, OrderedSet::t, and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by CondDBESSource::CondDBESSource(), and CondDBESSource::setIntervalFor().

◆ print_timestamp()

std::string cond::persistency::print_timestamp ( const boost::posix_time::ptime &  t,
const char *  format_s = "%Y-%m-%d %H:%M:%S.%f" 
)

Definition at line 86 of file Logger.cc.

86  :%M:%S.%f") {
87  boost::posix_time::time_facet* facet = new boost::posix_time::time_facet();
88  facet->format(format_s);
89  std::stringstream timestamp;
90  timestamp.imbue(std::locale(std::locale::classic(), facet));
91  timestamp << t;
92  return timestamp.str();
93  }

References OrderedSet::t, and cond::timestamp.

Referenced by get_timestamp(), and get_timestamp_for_filename().

◆ search()

template<typename T >
std::vector<T>::const_iterator cond::persistency::search ( const cond::Time_t val,
const std::vector< T > &  container 
)

◆ Session::storePayload< std::string >()

template<>
cond::Hash cond::persistency::Session::storePayload< std::string > ( const std::string &  payload,
const boost::posix_time::ptime &  creationTime 
)
inline

Definition at line 199 of file Session.h.

200  {
201  std::string payloadObjectType("std::string");
202  cond::Hash ret;
203  try {
204  ret = storePayloadData(payloadObjectType, serialize(payload), creationTime);
205  } catch (const cond::persistency::Exception& e) {
206  std::string em(e.what());
207  throwException("Payload of type " + payloadObjectType + " could not be stored. " + em, "Session::storePayload");
208  }
209  return ret;
210  }

References MillePedeFileConverter_cfg::e, jets_cff::payload, runTheMatrix::ret, cond::serialize(), AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

◆ setTillToLastIov()

void cond::persistency::setTillToLastIov ( cond::Iov_t target,
cond::Time_t  endOfValidity 
)

Definition at line 245 of file IOVProxy.cc.

245  {
246  if (endOfValidity < cond::time::MAX_VAL) {
247  if (target.since >= endOfValidity) {
248  target.clear();
249  } else {
250  target.till = endOfValidity;
251  }
252  } else {
254  }
255  }

References cond::time::MAX_VAL(), and filterCSVwithJSON::target.

Referenced by cond::persistency::IOVProxy::getLast(), and cond::persistency::IOVProxy::iovSequenceInfo().

◆ static_assert_is_same_decayed()

template<typename T , typename P >
void cond::persistency::static_assert_is_same_decayed ( )
inline

Definition at line 83 of file DbCore.h.

83  {
84  static_assert(std::is_same<typename std::decay<T>::type, typename std::decay<P>::type>::value,
85  "Parameter types don't match with the RowBuffer types");
86  };

◆ throwException()

void cond::persistency::throwException ( const std::string &  message,
const std::string &  methodName 
)

Definition at line 12 of file Exception.cc.

12  {
13  throw Exception(message, methodName);
14  }

Referenced by L1CondDBIOVWriterExt::analyze(), L1CondDBPayloadWriterExt::analyze(), L1CondDBIOVWriter::analyze(), L1CondDBPayloadWriter::analyze(), MillePedeAlignmentAlgorithm::beginRun(), cond::persistency::RunInfoEditor::checkTransaction(), cond::persistency::GTEditor::checkTransaction(), cond::persistency::IOVEditor::checkTransaction(), cond::persistency::RunInfoProxy::checkTransaction(), cond::persistency::GTProxy::checkTransaction(), cond::persistency::IOVProxy::checkTransaction(), convertoToOracleConnection(), copyIov(), cond::persistency::Session::coralSession(), cond::persistency::GLOBAL_TAG::Table::create(), cond::persistency::TAG::Table::create(), cond::persistency::RUN_INFO::Table::create(), cond::persistency::GLOBAL_TAG_MAP::Table::create(), cond::persistency::PAYLOAD::Table::create(), cond::persistency::IOV::Table::create(), cond::persistency::TAG_LOG::Table::create(), cond::persistency::Session::createGlobalTag(), cond::persistency::Session::createIov(), cond::persistency::Session::createIovForPayload(), cond::persistency::Query< Types... >::currentRow(), fetch(), fetchOne(), cond::persistency::Session::fetchPayload(), cond::persistency::RunInfoEditor::flush(), cond::persistency::GTEditor::flush(), cond::persistency::IOVEditor::flush(), cond::persistency::RunInfoProxy::get(), getConnectionProtocol(), cond::persistency::IOVProxy::getInterval(), cond::persistency::Session::getLastRun(), cond::persistency::IOVProxy::getMetadata(), cond::persistency::Session::getRunInfo(), cond::persistency::KeyList::getUsingIndex(), import(), importIovs(), MillePedeAlignmentAlgorithm::initialize(), cond::persistency::IOVProxy::iovSequenceInfo(), cond::persistency::GTEditor::load(), cond::persistency::RunInfoProxy::load(), cond::persistency::GTProxy::load(), cond::persistency::IOVProxy::load(), cond::persistency::KeyList::loadFromDB(), cond::persistency::PayloadProxy< std::vector< cond::Time_t > >::loadPayload(), makeHash(), cond::persistency::Query< Types... >::next(), cond::persistency::SessionImpl::openDb(), cond::persistency::SessionImpl::openGTDb(), cond::persistency::SessionImpl::openIovDb(), cond::persistency::SessionImpl::openRunInfoDb(), cond::persistency::PayloadProxy< std::vector< cond::Time_t > >::operator()(), cond::persistency::GetFromRow< std::array< char, n > >::operator()(), parseConnectionString(), cond::persistency::Logger::saveOnDb(), cond::persistency::IOVProxy::selectAll(), cond::persistency::IOVProxy::selectRange(), Session::storePayload< std::string >(), cond::setPermissionData(), cond::CredentialStore::startSession(), cond::persistency::SessionImpl::startTransaction(), cond::persistency::Session::storePayload(), cond::updateConnectionData(), and cond::updatePrincipalData().

runTheMatrix.ret
ret
prodAgent to be discontinued
Definition: runTheMatrix.py:355
PerformancePayloadFromTFormula
Definition: PerformancePayloadFromTFormula.h:17
CSCDBL1TPParameters
Definition: CSCDBL1TPParameters.h:14
ESGain
Definition: ESGain.h:7
SiPixelCPEGenericErrorParm
Definition: SiPixelCPEGenericErrorParm.h:15
service
Definition: service.py:1
CSCDBChipSpeedCorrection
Definition: CSCDBChipSpeedCorrection.h:9
DTTtrig
Definition: DTTtrig.h:68
ESMissingEnergyCalibration
Definition: ESMissingEnergyCalibration.h:7
CentralityTable
Definition: CentralityTable.h:7
L1MuCSCTFConfiguration
Definition: L1MuCSCTFConfiguration.h:9
TrackerDetToDTCELinkCablingMap
Definition: TrackerDetToDTCELinkCablingMap.h:29
EcalTPGWeightIdMap
Definition: EcalTPGWeightIdMap.h:10
HcalRespCorrs
Definition: HcalRespCorrs.h:17
cond::time::timeTypeName
std::string timeTypeName(TimeType type)
Definition: Time.cc:19
mps_fire.i
i
Definition: mps_fire.py:355
CastorGainWidths
Definition: CastorGainWidths.h:18
SiPixel2DTemplateDBObject
Definition: SiPixel2DTemplateDBObject.h:16
L1GtPrescaleFactors
Definition: L1GtPrescaleFactors.h:32
input
static const std::string input
Definition: EdmProvDump.cc:48
HcalMCParams
Definition: HcalMCParams.h:9
JetCorrectorParametersCollection
Definition: JetCorrectorParameters.h:139
JME::JetResolutionObject
Definition: JetResolutionObject.h:116
L1CaloHcalScale
Definition: L1CaloHcalScale.h:28
DTCELinkId
Definition: DTCELinkId.h:28
CSCRecoDigiParameters
Definition: CSCRecoDigiParameters.h:18
L1CaloEcalScale
Definition: L1CaloEcalScale.h:28
TrackProbabilityCalibration
Definition: TrackProbabilityCalibration.h:11
CSCBadStrips
Definition: CSCBadStrips.h:8
PTrackerParameters
Definition: PTrackerParameters.h:6
EcalPulseShape
Definition: EcalPulseShapes.h:8
DYTParamObject
Definition: DYTParamObject.h:8
cond::Hash
std::string Hash
Definition: Types.h:43
PerformanceWorkingPoint
Definition: PerformanceWorkingPoint.h:8
f
double f[11][100]
Definition: MuScleFitUtils.cc:78
DTDeadFlag
Definition: DTDeadFlag.h:66
SiStripNoises
Definition: SiStripNoises.h:25
cond::Binary
Definition: Binary.h:15
cond::persistency::fetchOne
std::pair< std::string, std::shared_ptr< void > > fetchOne(const std::string &payloadTypeName, const cond::Binary &data, const cond::Binary &streamerInfo, std::shared_ptr< void > payloadPtr)
Definition: CondDBFetch.cc:23
METCorrectorParametersCollection
Definition: METCorrectorParameters.h:106
cond::hash
Definition: Time.h:19
EcalTPGSpike
Definition: EcalTPGSpike.h:9
HcalTPParameters
Definition: HcalTPParameters.h:10
L1TUtmCutValue
Definition: L1TUtmCutValue.h:19
HcalTPChannelParameters
Definition: HcalTPChannelParameters.h:8
ESThresholds
Definition: ESThresholds.h:7
RPCObImon
Definition: RPCObCond.h:15
AlCaHLTBitMon_ParallelJobs.p
p
Definition: AlCaHLTBitMon_ParallelJobs.py:153
GBRForest
Definition: GBRForest.h:25
edmLumisInFiles.description
description
Definition: edmLumisInFiles.py:11
EcalTPGFineGrainStripEE
Definition: EcalTPGFineGrainStripEE.h:9
L1GtParameters
Definition: L1GtParameters.h:33
L1TUtmScale
Definition: L1TUtmScale.h:23
gather_cfg.cout
cout
Definition: gather_cfg.py:144
L1MuDTExtLut
Definition: L1MuDTExtLut.h:39
pos
Definition: PixelAliasList.h:18
SiPixelFEDChannelContainer
Definition: SiPixelFEDChannelContainer.h:12
L1GtBoardMaps
Definition: L1GtBoardMaps.h:33
AlignmentErrors
Definition: AlignmentErrors.h:10
EcalSampleMask
Definition: EcalSampleMask.h:16
DTRecoUncertainties
Definition: DTRecoUncertainties.h:19
L1TMuonGlobalParams
Definition: L1TMuonGlobalParams.h:21
EcalTPGFineGrainEBIdMap
Definition: EcalTPGFineGrainEBIdMap.h:10
EcalFunParams
Definition: EcalFunctionParameters.h:11
RPCAMCLinkMap
Definition: RPCAMCLinkMap.h:11
RPCObStatus
Definition: RPCObCond.h:49
EcalTimeOffsetConstant
Definition: EcalTimeOffsetConstant.h:13
PhysicsTFormulaPayload
Definition: PhysicsTFormulaPayload.h:9
L1RCTChannelMask
Definition: L1RCTChannelMask.h:7
L1MuDTTFMasks
Definition: L1MuDTTFMasks.h:36
AlignPCLThresholds
Definition: AlignPCLThresholds.h:11
lumi::LumiSectionData
Definition: LumiSectionData.h:69
L1MuGMTScales
Definition: L1MuGMTScales.h:34
EcalADCToGeVConstant
Definition: EcalADCToGeVConstant.h:13
RPCClusterSize
Definition: RPCClusterSize.h:10
HcalChannelQuality
Definition: HcalChannelQuality.h:17
DTMtime
Definition: DTMtime.h:68
RPCObTemp
Definition: RPCObCond.h:66
MuScleFitDBobject
Definition: MuScleFitDBobject.h:8
SiPixelCalibConfiguration
Definition: SiPixelCalibConfiguration.h:19
l1t::CaloConfig
Definition: CaloConfig.h:24
CSCBadChambers
Definition: CSCBadChambers.h:9
SiStripFedCabling
Contains cabling info at the device level, including DetId, APV pair numbers, hardware addresses,...
Definition: SiStripFedCabling.h:25
EcalTPGWeightGroup
Definition: EcalTPGWeightGroup.h:13
L1MuDTPtaLut
Definition: L1MuDTPtaLut.h:39
createJobs.tmp
tmp
align.sh
Definition: createJobs.py:716
EcalCondObjectContainer< EcalChannelStatusCode >
newFWLiteAna.found
found
Definition: newFWLiteAna.py:118
serviceName
static const std::string serviceName
Definition: CredentialStore.cc:31
edm::Service::isAvailable
bool isAvailable() const
Definition: Service.h:40
EcalTPGLutGroup
Definition: EcalTPGLutGroup.h:13
cond::synchronizationTypeNames
std::string synchronizationTypeNames(SynchronizationType type)
Definition: Types.cc:45
end
#define end
Definition: vmac.h:39
L1MuGMTChannelMask
Definition: L1MuGMTChannelMask.h:25
cond::persistency::fetch
std::pair< std::string, std::shared_ptr< void > > fetch(const cond::Hash &payloadId, Session &session)
Definition: CondDBFetch.cc:337
L1TriggerKey
Definition: L1TriggerKey.h:23
L1RPCConfig
Definition: L1RPCConfig.h:29
SiStripBadStrip
Definition: SiStripBadStrip.h:30
CSCDBGains
Definition: CSCDBGains.h:9
PCaloGeometry
Definition: PCaloGeometry.h:9
CSCDDUMap
Definition: CSCDDUMap.h:9
EcalCondTowerObjectContainer< EcalDAQStatusCode >
L1TUtmTriggerMenu
Definition: L1TUtmTriggerMenu.h:25
L1RCTNoisyChannelMask
Definition: L1RCTNoisyChannelMask.h:7
SiPixelDynamicInefficiency
Definition: SiPixelDynamicInefficiency.h:11
CSCDBCrosstalk
Definition: CSCDBCrosstalk.h:9
fileCollector.now
now
Definition: fileCollector.py:207
HcalPedestalWidths
Definition: HcalPedestalWidths.h:17
HcalPFCorrs
Definition: HcalPFCorrs.h:17
edm::FileInPath
Definition: FileInPath.h:64
L1TGlobalParameters
Definition: L1TGlobalParameters.h:7
optionsL1T.skip
skip
Definition: optionsL1T.py:30
HcalPedestals
Definition: HcalPedestals.h:20
alignCSCRings.s
s
Definition: alignCSCRings.py:92
EcalTPGSlidingWindow
Definition: EcalTPGSlidingWindow.h:9
CSCDBGasGainCorrection
Definition: CSCDBGasGainCorrection.h:9
EcalTPGFineGrainTowerEE
Definition: EcalTPGFineGrainTowerEE.h:9
L1MuTriggerPtScale
Definition: L1MuTriggerPtScale.h:33
RunInfo
Definition: RunInfo.h:18
HcalLUTCorrs
Definition: HcalLUTCorrs.h:20
CTPPSPixelAnalysisMask
Channel-mask mapping.
Definition: CTPPSPixelAnalysisMask.h:34
SiStripLorentzAngle
Definition: SiStripLorentzAngle.h:26
HcalL1TriggerObjects
Definition: HcalL1TriggerObjects.h:14
PerformancePayloadFromTable
Definition: PerformancePayloadFromTable.h:15
DYTThrObject
Definition: DYTThrObject.h:8
trigger::size_type
uint16_t size_type
Definition: TriggerTypeDefs.h:18
DTLVStatus
Definition: DTLVStatus.h:63
RPCEMap
Definition: RPCEMap.h:13
HBHENegativeEFilter
Definition: HBHENegativeEFilter.h:16
CSCDBPedestals
Definition: CSCDBPedestals.h:9
SiPixelGainCalibrationForHLT
Definition: SiPixelGainCalibrationForHLT.h:29
Calorimetry_cff.dp
dp
Definition: Calorimetry_cff.py:157
GlobalPosition_Frontier_DevDB_cff.tag
tag
Definition: GlobalPosition_Frontier_DevDB_cff.py:11
PHGCalParameters
Definition: PHGCalParameters.h:9
cuda_std::upper_bound
__host__ constexpr __device__ RandomIt upper_bound(RandomIt first, RandomIt last, const T &value, Compare comp={})
Definition: cudastdAlgorithm.h:45
RPCStripNoises
Definition: RPCStripNoises.h:10
cond::persistency::countslash
unsigned int countslash(const std::string &input)
Definition: DbConnectionString.cc:13
L1TGlobalPrescalesVetos
Definition: L1TGlobalPrescalesVetos.h:13
HcalItemCollById< HFPhase1PMTData >
QGLikelihoodSystematicsObject
QGLikelihoodSystematicsObject containing the parameters for the systematic smearing.
Definition: QGLikelihoodObject.h:38
cond::persistency::CoralXMLFile
Definition: ConnectionPool.h:32
SiPixelLorentzAngle
Definition: SiPixelLorentzAngle.h:11
cond::persistency::parseFipConnectionString
std::string parseFipConnectionString(const std::string &fipConnect)
Definition: DbConnectionString.cc:27
L1TMuonOverlapParams
Definition: L1TMuonOverlapParams.h:14
RPCObFebmap
Definition: RPCObFebmap.h:15
SiPixelGainCalibrationOffline
Definition: SiPixelGainCalibrationOffline.h:29
EcalPulseSymmCovariance
Definition: EcalPulseSymmCovariances.h:9
CSCChamberIndex
Definition: CSCChamberIndex.h:9
writeEcalDQMStatus.since
since
Definition: writeEcalDQMStatus.py:53
L1GtTriggerMask
Definition: L1GtTriggerMask.h:33
GBRForestD
Definition: GBRForestD.h:27
jets_cff.payload
payload
Definition: jets_cff.py:34
L1TUtmCondition
Definition: L1TUtmCondition.h:23
ESRecHitRatioCuts
Definition: ESRecHitRatioCuts.h:7
L1TUtmAlgorithm
Definition: L1TUtmAlgorithm.h:21
OrderedSet.t
t
Definition: OrderedSet.py:90
L1GtStableParameters
Definition: L1GtStableParameters.h:33
AlCaRecoTriggerBits
Definition: AlCaRecoTriggerBits.h:9
cond::Binary::get
const coral::Blob & get() const
Definition: Binary.cc:30
EcalTimeBiasCorrections
Definition: EcalTimeBiasCorrections.h:16
getGTfromDQMFile.obj
obj
Definition: getGTfromDQMFile.py:32
CastorPedestals
Definition: CastorPedestals.h:18
L1GctJetFinderParams
Definition: L1GctJetFinderParams.h:10
EcalTPGLutIdMap
Definition: EcalTPGLutIdMap.h:10
AlCaHLTBitMon_QueryRunRegistry.string
string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
QGLikelihoodCategory
Category structure: ranges associated with QGLikelihood histograms.
Definition: QGLikelihoodObject.h:9
RPCObGas
Definition: RPCObGas.h:15
L1TriggerKeyList
Definition: L1TriggerKeyList.h:32
cond::persistency::getConnectionProtocol
std::string getConnectionProtocol(const std::string &connectionString)
Definition: Utils.h:87
SiPixelQuality
Definition: SiPixelQuality.h:27
FETCH_PAYLOAD_CASE
#define FETCH_PAYLOAD_CASE(TYPENAME)
Definition: CondDBFetch.cc:3
CSCChamberTimeCorrections
Definition: CSCChamberTimeCorrections.h:9
RPFlatParams
Definition: RPFlatParams.h:7
L1GtTriggerMenu
Definition: L1GtTriggerMenu.h:48
L1RPCHwConfig
Definition: L1RPCHwConfig.h:65
HcalDcsValues
Definition: HcalDcsValues.h:25
DTTPGParameters
Definition: DTTPGParameters.h:62
CSCBadWires
Definition: CSCBadWires.h:8
L1CaloGeometry
Definition: L1CaloGeometry.h:33
signature
The Signals That Services Can Subscribe To This is based on ActivityRegistry and is current per Services can connect to the signals distributed by the ActivityRegistry in order to monitor the activity of the application Each possible callback has some defined signature
Definition: Activities.doc:4
EcalTPGFineGrainEBGroup
Definition: EcalTPGFineGrainEBGroup.h:13
L1TGlobalPrescalesVetosFract
Definition: L1TGlobalPrescalesVetosFract.h:13
KineDebug3::count
void count()
Definition: KinematicConstrainedVertexUpdatorT.h:21
cond::persistency::CondDbKey
Definition: ConnectionPool.h:32
L1RPCBxOrConfig
Definition: L1RPCBxOrConfig.h:26
CSCDBNoiseMatrix
Definition: CSCDBNoiseMatrix.h:9
cond::Time_t
unsigned long long Time_t
Definition: Time.h:14
match
std::pair< typename Association::data_type::first_type, double > match(Reference key, Association association, bool bestMatchByMaxValue)
Generic matching function.
Definition: Utils.h:10
MixingModuleConfig
Definition: MixingModuleConfig.h:71
ESTimeSampleWeights
Definition: ESTimeSampleWeights.h:7
CSCChamberMap
Definition: CSCChamberMap.h:11
HcalInterpolatedPulseColl
Definition: HcalInterpolatedPulseColl.h:8
HcalGainWidths
Definition: HcalGainWidths.h:17
MagFieldConfig
Definition: MagFieldConfig.h:26
CTPPSPixelGainCalibrations
Definition: CTPPSPixelGainCalibrations.h:8
SiPixelTemplateDBObject
Definition: SiPixelTemplateDBObject.h:16
edm::Service
Definition: Service.h:30
DropBoxMetadata
Definition: DropBoxMetadata.h:17
L1MuDTEtaPatternLut
Definition: L1MuDTEtaPatternLut.h:40
PhysicsTools::Calibration::Histogram2D
Definition: Histogram2D.h:20
cond::time::MAX_VAL
const Time_t MAX_VAL(std::numeric_limits< Time_t >::max())
DTKeyedConfig
Definition: DTKeyedConfig.h:35
L1CaloEtScale
Definition: L1CaloEtScale.h:29
value
Definition: value.py:1
SiStripDetVOff
Definition: SiStripDetVOff.h:31
CastorRecoParams
Definition: CastorRecoParams.h:9
cond::persistency::Exception
Base exception class for the object to relational access.
Definition: Exception.h:11
RPCLBLinkMap
Definition: RPCLBLinkMap.h:11
HcalTimeCorrs
Definition: HcalTimeCorrs.h:17
AlignmentSurfaceDeformations
Definition: AlignmentSurfaceDeformations.h:20
L1TUtmObject
Definition: L1TUtmObject.h:23
RawToDigi_cff.sourceTag
sourceTag
Definition: RawToDigi_cff.py:78
CastorGains
Definition: CastorGains.h:18
DBConfiguration_cff.connect
connect
Definition: DBConfiguration_cff.py:18
HLT_2018_cff.payloadType
payloadType
Definition: HLT_2018_cff.py:8133
IMPORT_PAYLOAD_CASE
#define IMPORT_PAYLOAD_CASE(TYPENAME)
Definition: CondDBImport.cc:4
BeamSpotObjects
Definition: BeamSpotObjects.h:20
ESMIPToGeVConstant
Definition: ESMIPToGeVConstant.h:7
L1MuTriggerScales
Definition: L1MuTriggerScales.h:33
AlignmentErrorsExtended
Definition: AlignmentErrorsExtended.h:10
ESCondObjectContainer
Definition: ESCondObjectContainer.h:11
PerformancePayloadFromBinnedTFormula
Definition: PerformancePayloadFromBinnedTFormula.h:17
CastorChannelQuality
Definition: CastorChannelQuality.h:17
HcalQIEData
Definition: HcalQIEData.h:24
goodZToMuMu_cfi.condition
condition
Definition: goodZToMuMu_cfi.py:37
MEtXYcorrectParametersCollection
Definition: MEtXYcorrectParameters.h:111
cmsLHEtoEOSManager.l
l
Definition: cmsLHEtoEOSManager.py:193
SiPixelFedCablingMap
Definition: SiPixelFedCablingMap.h:19
L1RPCHsbConfig
Definition: L1RPCHsbConfig.h:26
EcalTPGPhysicsConst
Definition: EcalTPGPhysicsConst.h:9
HcalElectronicsMap
Definition: HcalElectronicsMap.h:31
HLTMuonOfflineAnalyzer_cff.destination
destination
Definition: HLTMuonOfflineAnalyzer_cff.py:50
EcalSRSettings
Definition: EcalSRSettings.h:29
SiStripThreshold
Definition: __init__.py:1
EcalTPGTowerStatus
Definition: EcalTPGTowerStatus.h:9
SiPixelQualityProbabilities
Definition: SiPixelQualityProbabilities.h:10
HcalFlagHFDigiTimeParams
Definition: HcalFlagHFDigiTimeParams.h:9
type
type
Definition: HCALResponse.h:21
heppy_batch.val
val
Definition: heppy_batch.py:351
RPCObUXC
Definition: RPCObUXC.h:15
HcalLutMetadata
Definition: HcalLutMetadata.h:15
l1t::CaloParams
Definition: CaloParams.h:25
RPCObVmon
Definition: RPCObCond.h:32
init
Definition: init.py:1
RPCObPVSSmap
Definition: RPCObPVSSmap.h:16
cond::persistency::UndefinedAuthentication
Definition: ConnectionPool.h:32
PGeometricDetExtra
Definition: PGeometricDetExtra.h:9
triggerObjects_cff.id
id
Definition: triggerObjects_cff.py:31
T
long double T
Definition: Basic3DVectorLD.h:48
BeamSpotOnlineObjects
Definition: BeamSpotOnlineObjects.h:25
HcalZDCLowGainFractions
Definition: HcalZDCLowGainFractions.h:9
DTHVStatus
Definition: DTHVStatus.h:70
relativeConstraints.value
value
Definition: relativeConstraints.py:53
Exception
Definition: hltDiff.cc:246
HcalParameters
Definition: HcalParameters.h:6
CTPPSPixelDAQMapping
The mapping between FramePosition and ROCInfo.
Definition: CTPPSPixelDAQMapping.h:40
OOTPileupCorrectionBuffer
Definition: OOTPileupCorrectionBuffer.h:14
HcalGains
Definition: HcalGains.h:17
HcalRecoParams
Definition: HcalRecoParams.h:9
DTT0
Definition: DTT0.h:48
L1TUtmBin
Definition: L1TUtmBin.h:19
cond::serialize
std::pair< Binary, Binary > serialize(const T &payload)
Definition: Serialization.h:66
HcalFrontEndMap
Definition: HcalFrontEndMap.h:23
cond::persistency::print_timestamp
std::string print_timestamp(const boost::posix_time::ptime &t, const char *format_s="%Y-%m-%d %H:%M:%S.%f")
Definition: Logger.cc:86
CTPPSRPAlignmentCorrectionsData
Container for CTPPS RP alignment corrections. The corrections are stored on two levels - RP and senso...
Definition: CTPPSRPAlignmentCorrectionsData.h:24
Skims_PA_cff.name
name
Definition: Skims_PA_cff.py:17
PhysicsTools::Calibration::MVAComputerContainer
Definition: MVAComputer.h:250
edm::SiteLocalConfig::lookupCalibConnect
virtual const std::string lookupCalibConnect(std::string const &input) const =0
QGLikelihoodObject
QGLikelihoodObject containing valid range and entries with category and histogram (mean is not used a...
Definition: QGLikelihoodObject.h:22
RPCDCCLinkMap
Definition: RPCDCCLinkMap.h:11
L1RCTParameters
Definition: L1RCTParameters.h:27
StorableDoubleMap< AbsOOTPileupCorrection >
cond::persistency::throwException
void throwException(const std::string &message, const std::string &methodName)
Definition: Exception.cc:12
cond::persistency::is_same_any
constexpr bool is_same_any()
Definition: DbCore.h:280
PhysicsTools::Calibration::Histogram3D
Definition: Histogram3D.h:24
CastorPedestalWidths
Definition: CastorPedestalWidths.h:18
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:79
L1MuCSCPtLut
Definition: L1MuCSCPtLut.h:11
patCandidatesForDimuonsSequences_cff.matches
matches
Definition: patCandidatesForDimuonsSequences_cff.py:131
S
Definition: CSCDBL1TPParametersExtended.h:16
EcalTPGStripStatus
Definition: EcalTPGStripStatus.h:9
filterCSVwithJSON.target
target
Definition: filterCSVwithJSON.py:32
CSCCrateMap
Definition: CSCCrateMap.h:11
SiPixelGenErrorDBObject
Definition: SiPixelGenErrorDBObject.h:16
cond::persistency::importPayload
cond::Hash importPayload(Session &sourceSession, const cond::Hash &sourcePayloadId, Session &destSession, bool reserialize)
Definition: CondDBTools.cc:16
EcalPulseCovariance
Definition: EcalPulseCovariances.h:9
L1MuDTPhiLut
Definition: L1MuDTPhiLut.h:40
CastorElectronicsMap
Definition: CastorElectronicsMap.h:30
L1TMuonBarrelParams
Definition: L1TMuonBarrelParams.h:23
DTRecoConditions
Definition: DTRecoConditions.h:28
SiStripPedestals
Definition: SiStripPedestals.h:27
ESEEIntercalibConstants
Definition: ESEEIntercalibConstants.h:7
L1GctChannelMask
Definition: L1GctChannelMask.h:8
LHCOpticalFunctionsSetCollection
Collection of optical functions for two crossing angle values and various scoring planes....
Definition: LHCOpticalFunctionsSetCollection.h:16
HcalLongRecoParams
Definition: HcalLongRecoParams.h:9
RPCObGasMix
Definition: RPCObGasMix.h:15
CastorSaturationCorrs
Definition: CastorSaturationCorrs.h:9
EcalLaserAPDPNRatios
Definition: EcalLaserAPDPNRatios.h:14
PPSTimingCalibration
Definition: PPSTimingCalibration.h:17
CSCL1TPParameters
Definition: CSCL1TPParameters.h:14
CastorQIEData
Definition: CastorQIEData.h:25
cond::BaseKeyed
Definition: BaseKeyed.h:14
HcalZSThresholds
Definition: HcalZSThresholds.h:17
TableParser.table
table
Definition: TableParser.py:111
L1MuCSCTFAlignment
Definition: L1MuCSCTFAlignment.h:8
PhysicsTGraphPayload
Definition: PhysicsTGraphPayload.h:22
L1TUtmCut
Definition: L1TUtmCut.h:21
l1RCTOmdsFedVectorProducer_cfi.connectionString
connectionString
Definition: l1RCTOmdsFedVectorProducer_cfi.py:4
L1MuGMTParameters
Definition: L1MuGMTParameters.h:25
L1MuDTQualPatternLut
Definition: L1MuDTQualPatternLut.h:41
HcalSiPMParameters
Definition: HcalSiPMParameters.h:8
SiStripLatency
Definition: SiStripLatency.h:59
SiStripApvGain
Definition: SiStripApvGain.h:25
PGeometricDet
Definition: PGeometricDet.h:9
L1RPCConeDefinition
Definition: L1RPCConeDefinition.h:8
SiStripBackPlaneCorrection
Definition: SiStripBackPlaneCorrection.h:27
Alignments
Definition: Alignments.h:10
begin
#define begin
Definition: vmac.h:32
DTCCBConfig
Definition: DTCCBConfig.h:60
L1MuDTTFParameters
Definition: L1MuDTTFParameters.h:36
RecoIdealGeometry
Definition: RecoIdealGeometry.h:28
EcalTBWeights
Definition: EcalTBWeights.h:15
EcalTimeDependentCorrections
Definition: EcalTimeDependentCorrections.h:14
DTReadOutMapping
Definition: DTReadOutMapping.h:62
FileBlob
Definition: FileBlob.h:10
SiStripApvSimulationParameters
Definition: SiStripApvSimulationParameters.h:17
EcalSamplesCorrelation
Definition: EcalSamplesCorrelation.h:16
findQualityFiles.size
size
Write out results.
Definition: findQualityFiles.py:443
MillePedeFileConverter_cfg.e
e
Definition: MillePedeFileConverter_cfg.py:37
cond::throwException
void throwException(const std::string &message, const std::string &methodName)
Definition: Exception.cc:18
DTStatusFlag
Definition: DTStatusFlag.h:74
cond::persistency::f_add_attribute
void f_add_attribute(coral::AttributeList &data, const std::string &attributeName, const cond::SynchronizationType &param, bool init)
Definition: DbCore.h:130
SiStripConfObject
Definition: SiStripConfObject.h:31
L1GtPsbSetup
Definition: L1GtPsbSetup.h:32
HcalSiPMCharacteristics
Definition: HcalSiPMCharacteristics.h:18