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_AUTHORIZATION
 
 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  IDbAuthentication
 
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  IPayloadTable
 
class  IRunInfoSchema
 
class  IRunInfoTable
 
class  ITagAccessPermissionTable
 
class  ITagLogTable
 
class  ITagTable
 
class  ITransaction
 
class  KeyList
 
class  Logger
 
class  MsgDispatcher
 
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(), oniaPATMuonsWithTrigger_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 166 of file CondDBTools.cc.

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

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 submitPVResolutionJobs::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 111 of file DbCore.h.

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

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 101 of file DbCore.h.

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

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 131 of file DbCore.h.

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

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 121 of file DbCore.h.

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

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 91 of file DbCore.h.

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

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 142 of file DbCore.h.

142  {
143  static_assert_is_same_decayed<typename Column::type, P>();
145  }

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 266 of file DbCore.h.

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

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 166 of file DbCore.h.

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

◆ 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 149 of file DbCore.h.

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

References 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 340 of file CondDBFetch.cc.

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

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>)
249  //FETCH_PAYLOAD_CASE( PerformancePayload )
318 
319  //
320  if (payloadTypeName == "PhysicsTools::Calibration::Histogram3D<double,double,double,double>") {
321  payloadPtr = deserialize<PhysicsTools::Calibration::Histogram3D<double, double, double, double> >(
322  payloadTypeName, data, streamerInfo);
323  match = true;
324  }
325  if (payloadTypeName == "PhysicsTools::Calibration::Histogram2D<double,double,double>") {
326  payloadPtr = deserialize<PhysicsTools::Calibration::Histogram2D<double, double, double> >(
327  payloadTypeName, data, streamerInfo);
328  match = true;
329  }
330  if (payloadTypeName == "std::vector<unsignedlonglong,std::allocator<unsignedlonglong>>") {
331  payloadPtr = deserialize<std::vector<unsigned long long> >(payloadTypeName, data, streamerInfo);
332  match = true;
333  }
334 
335  if (!match)
336  throwException("Payload type \"" + payloadTypeName + "\" is unknown.", "fetch");
337  return std::make_pair(payloadTypeName, payloadPtr);
338  }

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 makeGlobalPositionRcd_cfg::tag.

Referenced by CondDBESSource::CondDBESSource().

◆ get_timestamp()

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

Definition at line 100 of file Logger.cc.

100  {
101  auto now = boost::posix_time::microsec_clock::universal_time();
102  return print_timestamp(now);
103  }

References submitPVValidationJobs::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 104 of file Logger.cc.

104  {
105  auto now = boost::posix_time::microsec_clock::universal_time();
106  return print_timestamp(now, "%Y-%m-%d_%H-%M-%S");
107  }

References submitPVValidationJobs::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>)
253  if (inputTypeName == "L1TriggerKeyList") {
254  match = true;
255  throwException("Import of \"L1TriggerKeyList\" type payloads is not supported.", "import");
256  }
257  //IMPORT_PAYLOAD_CASE( L1TriggerKeyList )
272  //IMPORT_PAYLOAD_CASE( PerformancePayload )
343  if (inputTypeName == "PhysicsTools::Calibration::Histogram3D<double,double,double,double>") {
344  match = true;
347  payloadId = destination.storePayload(obj, boost::posix_time::microsec_clock::universal_time());
348  }
349  if (inputTypeName == "PhysicsTools::Calibration::Histogram2D<double,double,double>") {
350  match = true;
353  payloadId = destination.storePayload(obj, boost::posix_time::microsec_clock::universal_time());
354  }
355  if (inputTypeName == "std::vector<unsignedlonglong,std::allocator<unsignedlonglong>>") {
356  match = true;
357  const std::vector<unsigned long long>& obj = *static_cast<const std::vector<unsigned long long>*>(inputPtr);
358  payloadId = destination.storePayload(obj, boost::posix_time::microsec_clock::universal_time());
359  }
360 
361  if (!match)
362  throwException("Payload type \"" + inputTypeName + "\" is unknown.", "import");
363  }
364  return payloadId;
365  }

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

Referenced by edm::python::initializePyBind11Module(), PyBind11ProcessDesc::prepareToRead(), 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 42 of file CondDBTools.cc.

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

References cond::persistency::Session::connectionString(), gather_cfg::cout, cond::persistency::Session::createDatabase(), cond::persistency::Session::createIov(), edmLumisInFiles::description, Calorimetry_cff::dp, cond::persistency::Session::editIov(), mps_fire::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 15 of file CondDBTools.cc.

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

References fetch(), cond::persistency::Session::fetchPayloadData(), submitPVValidationJobs::now, HLT_FULL_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 180 of file IOVEditor.cc.

181  {
182  return std::get<0>(f) < std::get<0>(s);
183  }

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 276 of file DbCore.h.

276  {
278  };

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 281 of file DbCore.h.

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

References is_same_any().

◆ makeHash()

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

Definition at line 11 of file IOVSchema.cc.

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

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 GlobalPosition_Frontier_DevDB_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, submitPVValidationJobs::t, and makeGlobalPositionRcd_cfg::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 91 of file Logger.cc.

91  :%M:%S.%f") {
92  boost::posix_time::time_facet* facet = new boost::posix_time::time_facet();
93  facet->format(format_s);
94  std::stringstream timestamp;
95  timestamp.imbue(std::locale(std::locale::classic(), facet));
96  timestamp << t;
97  return timestamp.str();
98  }

References submitPVValidationJobs::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 BeamSpotPI::creationTime, 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 255 of file IOVProxy.cc.

255  {
256  if (endOfValidity < cond::time::MAX_VAL) {
257  if (target.since >= endOfValidity) {
258  target.clear();
259  } else {
260  target.till = endOfValidity;
261  }
262  } else {
264  }
265  }

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 84 of file DbCore.h.

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

◆ 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_AUTHORIZATION::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::persistency::TAG::Table::setProtectionCode(), cond::CredentialStore::startSession(), cond::persistency::SessionImpl::startTransaction(), cond::persistency::Session::storePayload(), cond::persistency::IOVSchema::tagAccessPermissionTable(), cond::persistency::TAG::Table::unsetProtectionCode(), cond::updateConnectionData(), and cond::updatePrincipalData().

runTheMatrix.ret
ret
prodAgent to be discontinued
Definition: runTheMatrix.py:543
PerformancePayloadFromTFormula
Definition: PerformancePayloadFromTFormula.h:17
CSCDBL1TPParameters
Definition: CSCDBL1TPParameters.h:14
pfDeepBoostedJetPreprocessParams_cfi.upper_bound
upper_bound
Definition: pfDeepBoostedJetPreprocessParams_cfi.py:16
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:8
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:428
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:148
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
submitPVValidationJobs.now
now
Definition: submitPVValidationJobs.py:639
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
GBRForest
Definition: GBRForest.h:24
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
PTrackerAdditionalParametersPerDet
Definition: PTrackerAdditionalParametersPerDet.h:9
oniaPATMuonsWithTrigger_cff.matches
matches
Definition: oniaPATMuonsWithTrigger_cff.py:77
DTRecoUncertainties
Definition: DTRecoUncertainties.h:19
L1TMuonGlobalParams
Definition: L1TMuonGlobalParams.h:21
EcalTPGFineGrainEBIdMap
Definition: EcalTPGFineGrainEBIdMap.h:10
PPSAlignmentConfig
Definition: PPSAlignmentConfig.h:96
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:8
L1MuDTPtaLut
Definition: L1MuDTPtaLut.h:39
createJobs.tmp
tmp
align.sh
Definition: createJobs.py:716
EcalCondObjectContainer
Definition: EcalCondObjectContainer.h:13
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
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:340
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
SiPhase2OuterTrackerLorentzAngle
Definition: SiPhase2OuterTrackerLorentzAngle.h:26
EcalCondTowerObjectContainer
Definition: EcalCondTowerObjectContainer.h:13
L1TUtmTriggerMenu
Definition: L1TUtmTriggerMenu.h:25
L1RCTNoisyChannelMask
Definition: L1RCTNoisyChannelMask.h:7
SiPixelDynamicInefficiency
Definition: SiPixelDynamicInefficiency.h:11
CSCDBCrosstalk
Definition: CSCDBCrosstalk.h:9
HcalPedestalWidths
Definition: HcalPedestalWidths.h:17
HcalPFCorrs
Definition: HcalPFCorrs.h:17
edm::FileInPath
Definition: FileInPath.h:61
L1TGlobalParameters
Definition: L1TGlobalParameters.h:7
optionsL1T.skip
skip
Definition: optionsL1T.py:30
HcalPedestals
Definition: HcalPedestals.h:20
GlobalPosition_Frontier_DevDB_cff.connect
connect
Definition: GlobalPosition_Frontier_DevDB_cff.py:8
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:158
PHGCalParameters
Definition: PHGCalParameters.h:9
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
mps_fire.end
end
Definition: mps_fire.py:242
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:11
CSCChamberIndex
Definition: CSCChamberIndex.h:9
submitPVResolutionJobs.count
count
Definition: submitPVResolutionJobs.py:352
writeEcalDQMStatus.since
since
Definition: writeEcalDQMStatus.py:53
L1GtTriggerMask
Definition: L1GtTriggerMask.h:33
GBRForestD
Definition: GBRForestD.h:25
jets_cff.payload
payload
Definition: jets_cff.py:32
L1TUtmCondition
Definition: L1TUtmCondition.h:23
ESRecHitRatioCuts
Definition: ESRecHitRatioCuts.h:7
L1TUtmAlgorithm
Definition: L1TUtmAlgorithm.h:21
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
SiPixelVCal
Definition: SiPixelVCal.h:9
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
AlCaHLTBitMon_ParallelJobs.p
def p
Definition: AlCaHLTBitMon_ParallelJobs.py:153
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
makeGlobalPositionRcd_cfg.tag
tag
Definition: makeGlobalPositionRcd_cfg.py:6
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
cond::persistency::CondDbKey
Definition: ConnectionPool.h:32
L1RPCBxOrConfig
Definition: L1RPCBxOrConfig.h:26
gainCalibHelper::gainCalibPI::type
type
Definition: SiPixelGainCalibHelper.h:40
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:79
CastorGains
Definition: CastorGains.h:18
IMPORT_PAYLOAD_CASE
#define IMPORT_PAYLOAD_CASE(TYPENAME)
Definition: CondDBImport.cc:4
BeamSpotObjects
Definition: BeamSpotObjects.h:20
BeamSpotPI::creationTime
Definition: BeamSpotPayloadInspectorHelper.h:44
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
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
CastorChannelQuality
Definition: CastorChannelQuality.h:17
HcalQIEData
Definition: HcalQIEData.h:24
MEtXYcorrectParametersCollection
Definition: MEtXYcorrectParameters.h:111
cmsLHEtoEOSManager.l
l
Definition: cmsLHEtoEOSManager.py:204
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:27
SiStripThreshold
Definition: __init__.py:1
HLT_FULL_cff.payloadType
payloadType
Definition: HLT_FULL_cff.py:9457
EcalTPGTowerStatus
Definition: EcalTPGTowerStatus.h:9
SiPixelQualityProbabilities
Definition: SiPixelQualityProbabilities.h:10
HcalFlagHFDigiTimeParams
Definition: HcalFlagHFDigiTimeParams.h:9
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
triggerObjects_cff.id
id
Definition: triggerObjects_cff.py:29
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:245
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:91
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:281
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
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:15
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
submitPVValidationJobs.t
string t
Definition: submitPVValidationJobs.py:644
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
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:11
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:131
SiStripConfObject
Definition: SiStripConfObject.h:31
L1GtPsbSetup
Definition: L1GtPsbSetup.h:32
HcalSiPMCharacteristics
Definition: HcalSiPMCharacteristics.h:18