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<typename T >
void f_add_attribute (coral::AttributeList &data, const std::string &attributeName, const T &param, bool init=true)
 
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 boost::posix_time::ptime &param, bool init)
 
template<>
void f_add_attribute (coral::AttributeList &data, const std::string &attributeName, const cond::TimeType &param, bool init)
 
template<>
void f_add_attribute (coral::AttributeList &data, const std::string &attributeName, const cond::SynchronizationType &param, bool init)
 
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

enum cond::persistency::DbAuthenticationSystem
Enumerator
UndefinedAuthentication 
CondDbKey 
CoralXMLFile 

Definition at line 32 of file ConnectionPool.h.

32 { UndefinedAuthentication = 0, CondDbKey, CoralXMLFile };

Function Documentation

◆ convertoToOracleConnection()

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

Definition at line 120 of file Utils.h.

References input, ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, oniaPATMuonsWithTrigger_cff::matches, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

Referenced by CondDBESSource::CondDBESSource().

120  {
121  // leave the connection string unmodified for sqlite
122  if (input.find("sqlite") == 0 || input.find("oracle") == 0)
123  return input;
124 
125  //static const std::regex trivial("oracle://(cms_orcon_adg|cms_orcoff_prep)/([_[:alnum:]]+?)");
126  static const std::regex short_frontier("frontier://([[:alnum:]]+?)/([_[:alnum:]]+?)");
127  static const std::regex long_frontier("frontier://((\\([-[:alnum:]]+?=[^\\)]+?\\))+)/([_[:alnum:]]+?)");
128  static const std::regex long_frontier_serverurl("\\(serverurl=[^\\)]+?/([[:alnum:]]+?)\\)");
129 
130  static const std::map<std::string, std::string> frontierMap = {
131  {"PromptProd", "cms_orcon_adg"},
132  {"FrontierProd", "cms_orcon_adg"},
133  {"FrontierArc", "cms_orcon_adg"},
134  {"FrontierOnProd", "cms_orcon_adg"},
135  {"FrontierPrep", "cms_orcoff_prep"},
136  };
137 
138  std::smatch matches;
139 
140  static const std::string technology("oracle://");
141  std::string service("");
142  std::string account("");
143 
144  bool match = false;
145  if (std::regex_match(input, matches, short_frontier)) {
146  service = matches[1];
147  account = matches[2];
148  match = true;
149  } else if (std::regex_match(input, matches, long_frontier)) {
150  std::string frontier_config(matches[1]);
151  std::smatch matches2;
152  if (not std::regex_search(frontier_config, matches2, long_frontier_serverurl))
153  throwException("No serverurl in matched long frontier", "convertoToOracleConnection");
154  service = matches2[1];
155  account = matches[3];
156  match = true;
157  }
158 
159  if (!match)
160  throwException("Connection string " + input + " can't be converted to oracle connection.",
161  "convertoToOracleConnection");
162 
163  if (service == "FrontierArc") {
164  size_t len = account.size() - 5;
165  account = account.substr(0, len);
166  }
167 
168  auto it = frontierMap.find(service);
169  if (it == frontierMap.end())
170  throwException("Connection string can't be converted.", "convertoToOracleConnection");
171  service = it->second;
172 
173  return technology + service + "/" + account;
174  }
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
input
static std::string const input
Definition: EdmProvDump.cc:50
ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it
auto & it
Definition: splitVertices.h:45
oniaPATMuonsWithTrigger_cff.matches
matches
Definition: oniaPATMuonsWithTrigger_cff.py:77
match
std::pair< typename Association::data_type::first_type, double > match(Reference key, Association association, bool bestMatchByMaxValue)
Generic matching function.
Definition: Utils.h:10
cond::persistency::throwException
void throwException(const std::string &message, const std::string &methodName)
Definition: Exception.cc:12

◆ 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 163 of file CondDBTools.cc.

References gather_cfg::cout, cond::persistency::Session::createIov(), makeListRunsInFiles::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().

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

◆ countslash()

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

Definition at line 13 of file DbConnectionString.cc.

References submitPVResolutionJobs::count, and input.

Referenced by getConnectionParams().

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  }
trigger::size_type
uint16_t size_type
Definition: TriggerTypeDefs.h:18
input
static std::string const input
Definition: EdmProvDump.cc:50

◆ f_add_attribute() [1/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.

References data.

Referenced by f_add_column_data(), and f_add_condition_data().

94  {
95  if (init)
96  data.extend<T>(attributeName);
97  data[attributeName].data<T>() = param;
98  }
init
Definition: init.py:1
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:80
T
long double T
Definition: Basic3DVectorLD.h:48

◆ 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.

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

104  {
105  if (init)
106  data.extend<coral::Blob>(attributeName);
107  data[attributeName].bind(param.get());
108  }
init
Definition: init.py:1
cond::Binary::get
const coral::Blob & get() const
Definition: Binary.cc:30
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:80

◆ f_add_attribute() [3/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.

References data.

114  {
115  if (init)
116  data.extend<coral::TimeStamp>(attributeName);
117  data[attributeName].data<coral::TimeStamp>() = coral::TimeStamp(param);
118  }
init
Definition: init.py:1
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:80

◆ 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.

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

124  {
125  if (init)
126  data.extend<std::string>(attributeName);
127  data[attributeName].data<std::string>() = cond::time::timeTypeName(param);
128  }
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
init
Definition: init.py:1
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:80
cond::time::timeTypeName
std::string timeTypeName(TimeType type)
Definition: Time.cc:19

◆ f_add_attribute() [5/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.

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

134  {
135  if (init)
136  data.extend<std::string>(attributeName);
137  data[attributeName].data<std::string>() = synchronizationTypeNames(param);
138  }
cond::synchronizationTypeNames
std::string synchronizationTypeNames(SynchronizationType type)
Definition: Types.cc:45
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
init
Definition: init.py:1
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:80

◆ 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.

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

142  {
143  static_assert_is_same_decayed<typename Column::type, P>();
144  f_add_attribute(data, Column::name, param, init);
145  }
init
Definition: init.py:1
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:80
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
Skims_PA_cff.name
name
Definition: Skims_PA_cff.py:17

◆ 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.

References TableParser::table.

269  {
270  table.insertColumn(columnName, AttributeTypeName<T>()(), size);
271  if (notNull)
272  table.setNotNullConstraint(columnName);
273  }
findQualityFiles.size
size
Write out results.
Definition: findQualityFiles.py:443

◆ 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.

References data, f_add_attribute(), l1ctLayer2EG_cff::id, Skims_PA_cff::name, and relativeConstraints::value.

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  }
l1ctLayer2EG_cff.id
id
Definition: l1ctLayer2EG_cff.py:85
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:80
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
Skims_PA_cff.name
name
Definition: Skims_PA_cff.py:17

◆ fetch()

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

Definition at line 352 of file CondDBFetch.cc.

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

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

352  {
353  std::shared_ptr<void> payloadPtr;
354  cond::Binary data;
355  cond::Binary streamerInfo;
356  std::string payloadTypeName;
357  bool found = session.fetchPayloadData(payloadId, payloadTypeName, data, streamerInfo);
358  if (!found)
359  throwException("Payload with id " + payloadId + " has not been found in the database.", "fetch");
360  return fetchOne(payloadTypeName, data, streamerInfo, payloadPtr);
361  }
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
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:80
cond::persistency::throwException
void throwException(const std::string &message, const std::string &methodName)
Definition: Exception.cc:12

◆ 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.

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

27  {
28  std::shared_ptr<void> payloadPtr;
29  cond::Binary data;
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  }
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
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:80

◆ 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.

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

Referenced by fetch(), and fetchIfExists().

26  {
27  bool match = false;
28  FETCH_PAYLOAD_CASE(std::string)
29  FETCH_PAYLOAD_CASE(std::vector<unsigned long long>)
30  FETCH_PAYLOAD_CASE(AlCaRecoTriggerBits)
31  FETCH_PAYLOAD_CASE(AlignmentErrors)
32  FETCH_PAYLOAD_CASE(AlignmentErrorsExtended)
33  FETCH_PAYLOAD_CASE(AlignmentSurfaceDeformations)
34  FETCH_PAYLOAD_CASE(Alignments)
35  FETCH_PAYLOAD_CASE(AlignPCLThresholds)
36  FETCH_PAYLOAD_CASE(AlignPCLThresholdsHG)
37  FETCH_PAYLOAD_CASE(BeamSpotObjects)
38  FETCH_PAYLOAD_CASE(BeamSpotOnlineObjects)
39  FETCH_PAYLOAD_CASE(CSCBadChambers)
40  FETCH_PAYLOAD_CASE(CSCBadStrips)
41  FETCH_PAYLOAD_CASE(CSCBadWires)
42  FETCH_PAYLOAD_CASE(CSCChamberIndex)
43  FETCH_PAYLOAD_CASE(CSCChamberMap)
44  FETCH_PAYLOAD_CASE(CSCChamberTimeCorrections)
45  FETCH_PAYLOAD_CASE(CSCCrateMap)
46  FETCH_PAYLOAD_CASE(CSCDBChipSpeedCorrection)
47  FETCH_PAYLOAD_CASE(CSCDBCrosstalk)
48  FETCH_PAYLOAD_CASE(CSCDBGains)
49  FETCH_PAYLOAD_CASE(CSCDBGasGainCorrection)
50  FETCH_PAYLOAD_CASE(CSCDBL1TPParameters)
51  FETCH_PAYLOAD_CASE(CSCDBNoiseMatrix)
52  FETCH_PAYLOAD_CASE(CSCDBPedestals)
53  FETCH_PAYLOAD_CASE(CSCDDUMap)
54  FETCH_PAYLOAD_CASE(CSCL1TPParameters)
55  FETCH_PAYLOAD_CASE(CSCRecoDigiParameters)
56  FETCH_PAYLOAD_CASE(CTPPSPixelDAQMapping)
57  FETCH_PAYLOAD_CASE(CTPPSPixelAnalysisMask)
58  FETCH_PAYLOAD_CASE(CTPPSPixelGainCalibrations)
59  FETCH_PAYLOAD_CASE(CTPPSRPAlignmentCorrectionsData)
60  FETCH_PAYLOAD_CASE(PPSAlignmentConfiguration)
61  FETCH_PAYLOAD_CASE(PPSAssociationCuts)
62  FETCH_PAYLOAD_CASE(LHCOpticalFunctionsSetCollection)
63  FETCH_PAYLOAD_CASE(CastorChannelQuality)
64  FETCH_PAYLOAD_CASE(CastorElectronicsMap)
65  FETCH_PAYLOAD_CASE(CastorGainWidths)
66  FETCH_PAYLOAD_CASE(CastorGains)
67  FETCH_PAYLOAD_CASE(CastorPedestalWidths)
68  FETCH_PAYLOAD_CASE(CastorPedestals)
69  FETCH_PAYLOAD_CASE(CastorQIEData)
70  FETCH_PAYLOAD_CASE(CastorRecoParams)
71  FETCH_PAYLOAD_CASE(CastorSaturationCorrs)
72  FETCH_PAYLOAD_CASE(CentralityTable)
73  FETCH_PAYLOAD_CASE(DTCCBConfig)
74  FETCH_PAYLOAD_CASE(DTDeadFlag)
75  FETCH_PAYLOAD_CASE(DTHVStatus)
76  FETCH_PAYLOAD_CASE(DTKeyedConfig)
77  FETCH_PAYLOAD_CASE(DTLVStatus)
78  FETCH_PAYLOAD_CASE(DTMtime)
79  FETCH_PAYLOAD_CASE(DTReadOutMapping)
80  FETCH_PAYLOAD_CASE(DTRecoConditions)
81  FETCH_PAYLOAD_CASE(DTRecoUncertainties)
82  FETCH_PAYLOAD_CASE(DTStatusFlag)
83  FETCH_PAYLOAD_CASE(DTT0)
84  FETCH_PAYLOAD_CASE(DTTPGParameters)
85  FETCH_PAYLOAD_CASE(DTTtrig)
86  FETCH_PAYLOAD_CASE(DropBoxMetadata)
87  FETCH_PAYLOAD_CASE(ESChannelStatus)
88  FETCH_PAYLOAD_CASE(ESEEIntercalibConstants)
89  FETCH_PAYLOAD_CASE(ESFloatCondObjectContainer)
90  FETCH_PAYLOAD_CASE(ESGain)
91  FETCH_PAYLOAD_CASE(ESMIPToGeVConstant)
92  FETCH_PAYLOAD_CASE(ESMissingEnergyCalibration)
93  FETCH_PAYLOAD_CASE(ESPedestals)
94  FETCH_PAYLOAD_CASE(ESRecHitRatioCuts)
95  FETCH_PAYLOAD_CASE(ESThresholds)
96  FETCH_PAYLOAD_CASE(ESTimeSampleWeights)
97  FETCH_PAYLOAD_CASE(EcalADCToGeVConstant)
98  FETCH_PAYLOAD_CASE(EcalChannelStatus)
99  FETCH_PAYLOAD_CASE(EcalClusterEnergyCorrectionObjectSpecificParameters)
100  FETCH_PAYLOAD_CASE(EcalDAQTowerStatus)
101  FETCH_PAYLOAD_CASE(EcalDCSTowerStatus)
102  FETCH_PAYLOAD_CASE(EcalDQMChannelStatus)
103  FETCH_PAYLOAD_CASE(EcalDQMTowerStatus)
104  FETCH_PAYLOAD_CASE(EcalFloatCondObjectContainer)
105  FETCH_PAYLOAD_CASE(EcalFunParams)
106  FETCH_PAYLOAD_CASE(EcalGainRatios)
107  FETCH_PAYLOAD_CASE(EcalLaserAPDPNRatios)
108  FETCH_PAYLOAD_CASE(EcalMappingElectronics)
109  FETCH_PAYLOAD_CASE(EcalCondObjectContainer<EcalMappingElement>)
110  FETCH_PAYLOAD_CASE(EcalCondObjectContainer<EcalPedestal>)
111  FETCH_PAYLOAD_CASE(EcalCondObjectContainer<EcalTPGLinearizationConstant>)
112  FETCH_PAYLOAD_CASE(EcalCondObjectContainer<EcalDQMStatusCode>)
113  FETCH_PAYLOAD_CASE(EcalCondObjectContainer<EcalTPGCrystalStatusCode>)
114  FETCH_PAYLOAD_CASE(EcalCondTowerObjectContainer<EcalDAQStatusCode>)
115  FETCH_PAYLOAD_CASE(EcalCondTowerObjectContainer<EcalChannelStatusCode>)
116  FETCH_PAYLOAD_CASE(EcalCondTowerObjectContainer<EcalDQMStatusCode>)
117  FETCH_PAYLOAD_CASE(EcalPedestals)
118  FETCH_PAYLOAD_CASE(EcalSRSettings)
119  FETCH_PAYLOAD_CASE(EcalSampleMask)
120  FETCH_PAYLOAD_CASE(EcalTBWeights)
121  FETCH_PAYLOAD_CASE(EcalTimeBiasCorrections)
122  FETCH_PAYLOAD_CASE(EcalTimeDependentCorrections)
123  FETCH_PAYLOAD_CASE(EcalTPGCrystalStatus)
124  FETCH_PAYLOAD_CASE(EcalTPGFineGrainEBGroup)
125  FETCH_PAYLOAD_CASE(EcalTPGFineGrainEBIdMap)
126  FETCH_PAYLOAD_CASE(EcalTPGFineGrainStripEE)
127  FETCH_PAYLOAD_CASE(EcalTPGFineGrainTowerEE)
128  FETCH_PAYLOAD_CASE(EcalTPGLinearizationConst)
129  FETCH_PAYLOAD_CASE(EcalTPGLutGroup)
130  FETCH_PAYLOAD_CASE(EcalTPGLutIdMap)
131  FETCH_PAYLOAD_CASE(EcalTPGPedestals)
132  FETCH_PAYLOAD_CASE(EcalTPGPhysicsConst)
133  FETCH_PAYLOAD_CASE(EcalTPGSlidingWindow)
134  FETCH_PAYLOAD_CASE(EcalTPGSpike)
135  FETCH_PAYLOAD_CASE(EcalTPGStripStatus)
136  FETCH_PAYLOAD_CASE(EcalTPGTowerStatus)
137  FETCH_PAYLOAD_CASE(EcalTPGWeightGroup)
138  FETCH_PAYLOAD_CASE(EcalTPGWeightIdMap)
139  FETCH_PAYLOAD_CASE(EcalTimeOffsetConstant)
140  FETCH_PAYLOAD_CASE(EcalWeightXtalGroups)
141  FETCH_PAYLOAD_CASE(EcalSamplesCorrelation)
142  FETCH_PAYLOAD_CASE(EcalCondObjectContainer<EcalPulseShape>)
143  FETCH_PAYLOAD_CASE(EcalPulseShape)
144  FETCH_PAYLOAD_CASE(EcalCondObjectContainer<EcalPulseCovariance>)
145  FETCH_PAYLOAD_CASE(EcalPulseCovariance)
146  FETCH_PAYLOAD_CASE(EcalCondObjectContainer<EcalPulseSymmCovariance>)
147  FETCH_PAYLOAD_CASE(EcalPulseSymmCovariance)
148  FETCH_PAYLOAD_CASE(EcalEBPhase2TPGAmplWeightIdMap)
149  FETCH_PAYLOAD_CASE(EcalEBPhase2TPGAmplWeights)
150  FETCH_PAYLOAD_CASE(EcalEBPhase2TPGTimeWeightIdMap)
151  FETCH_PAYLOAD_CASE(EcalEBPhase2TPGTimeWeights)
152  FETCH_PAYLOAD_CASE(EcalEBPhase2TPGLinearizationConstant)
153  FETCH_PAYLOAD_CASE(EcalEBPhase2TPGPedestal)
154  FETCH_PAYLOAD_CASE(FileBlob)
155  FETCH_PAYLOAD_CASE(GBRForest)
156  FETCH_PAYLOAD_CASE(GBRForestD)
157  FETCH_PAYLOAD_CASE(HBHENegativeEFilter)
158  FETCH_PAYLOAD_CASE(HFPhase1PMTParams)
159  FETCH_PAYLOAD_CASE(HcalChannelQuality)
160  FETCH_PAYLOAD_CASE(HcalDcsValues)
161  FETCH_PAYLOAD_CASE(HcalElectronicsMap)
162  FETCH_PAYLOAD_CASE(HcalFlagHFDigiTimeParams)
163  FETCH_PAYLOAD_CASE(HcalFrontEndMap)
164  FETCH_PAYLOAD_CASE(HcalGains)
165  FETCH_PAYLOAD_CASE(HcalGainWidths)
166  FETCH_PAYLOAD_CASE(HcalL1TriggerObjects)
167  FETCH_PAYLOAD_CASE(HcalLUTCorrs)
168  FETCH_PAYLOAD_CASE(HcalLongRecoParams)
169  FETCH_PAYLOAD_CASE(HcalZDCLowGainFractions)
170  FETCH_PAYLOAD_CASE(HcalLutMetadata)
171  FETCH_PAYLOAD_CASE(HcalMCParams)
172  FETCH_PAYLOAD_CASE(HcalPFCorrs)
173  FETCH_PAYLOAD_CASE(HcalPFCuts)
174  FETCH_PAYLOAD_CASE(HcalPedestalWidths)
175  FETCH_PAYLOAD_CASE(HcalPedestals)
176  FETCH_PAYLOAD_CASE(HcalQIEData)
177  FETCH_PAYLOAD_CASE(HcalSiPMCharacteristics)
178  FETCH_PAYLOAD_CASE(HcalSiPMParameters)
179  FETCH_PAYLOAD_CASE(HcalRecoParams)
180  FETCH_PAYLOAD_CASE(HcalRespCorrs)
181  FETCH_PAYLOAD_CASE(HcalTimeCorrs)
182  FETCH_PAYLOAD_CASE(HcalTPChannelParameters)
183  FETCH_PAYLOAD_CASE(HcalTPParameters)
184  FETCH_PAYLOAD_CASE(HcalZSThresholds)
185  FETCH_PAYLOAD_CASE(HcalInterpolatedPulseColl)
186  FETCH_PAYLOAD_CASE(OOTPileupCorrectionBuffer)
187  FETCH_PAYLOAD_CASE(StorableDoubleMap<AbsOOTPileupCorrection>)
188  FETCH_PAYLOAD_CASE(JetCorrectorParametersCollection)
189  FETCH_PAYLOAD_CASE(JME::JetResolutionObject)
190  FETCH_PAYLOAD_CASE(METCorrectorParametersCollection)
191  FETCH_PAYLOAD_CASE(MEtXYcorrectParametersCollection)
192  FETCH_PAYLOAD_CASE(L1CaloEcalScale)
193  FETCH_PAYLOAD_CASE(L1CaloEtScale)
194  FETCH_PAYLOAD_CASE(L1CaloGeometry)
195  FETCH_PAYLOAD_CASE(L1CaloHcalScale)
196  FETCH_PAYLOAD_CASE(L1GctChannelMask)
197  FETCH_PAYLOAD_CASE(L1GctJetFinderParams)
198  FETCH_PAYLOAD_CASE(L1GtBoardMaps)
199  FETCH_PAYLOAD_CASE(L1GtParameters)
200  FETCH_PAYLOAD_CASE(L1GtPrescaleFactors)
201  FETCH_PAYLOAD_CASE(L1GtPsbSetup)
202  FETCH_PAYLOAD_CASE(L1GtStableParameters)
203  FETCH_PAYLOAD_CASE(L1GtTriggerMask)
204  FETCH_PAYLOAD_CASE(L1GtTriggerMenu)
205  FETCH_PAYLOAD_CASE(L1MuCSCPtLut)
206  FETCH_PAYLOAD_CASE(L1MuCSCTFAlignment)
207  FETCH_PAYLOAD_CASE(L1MuCSCTFConfiguration)
208  FETCH_PAYLOAD_CASE(L1MuDTEtaPatternLut)
209  FETCH_PAYLOAD_CASE(L1MuDTExtLut)
210  FETCH_PAYLOAD_CASE(L1MuDTPhiLut)
211  FETCH_PAYLOAD_CASE(L1MuDTPtaLut)
212  FETCH_PAYLOAD_CASE(L1MuDTQualPatternLut)
213  FETCH_PAYLOAD_CASE(L1MuDTTFMasks)
214  FETCH_PAYLOAD_CASE(L1MuDTTFParameters)
215  FETCH_PAYLOAD_CASE(L1MuGMTChannelMask)
216  FETCH_PAYLOAD_CASE(L1MuGMTParameters)
217  FETCH_PAYLOAD_CASE(L1MuGMTScales)
218  FETCH_PAYLOAD_CASE(L1MuTriggerPtScale)
219  FETCH_PAYLOAD_CASE(L1MuTriggerScales)
220  FETCH_PAYLOAD_CASE(L1RCTChannelMask)
221  FETCH_PAYLOAD_CASE(L1RCTNoisyChannelMask)
222  FETCH_PAYLOAD_CASE(L1RCTParameters)
223  FETCH_PAYLOAD_CASE(L1RPCBxOrConfig)
224  FETCH_PAYLOAD_CASE(L1RPCConeDefinition)
225  FETCH_PAYLOAD_CASE(L1RPCConfig)
226  FETCH_PAYLOAD_CASE(L1RPCHsbConfig)
227  FETCH_PAYLOAD_CASE(L1RPCHwConfig)
228  FETCH_PAYLOAD_CASE(l1t::CaloParams)
229  FETCH_PAYLOAD_CASE(l1t::CaloConfig)
230  FETCH_PAYLOAD_CASE(L1TMuonBarrelParams)
231  FETCH_PAYLOAD_CASE(L1TMuonGlobalParams)
232  FETCH_PAYLOAD_CASE(L1TMuonOverlapParams)
233  FETCH_PAYLOAD_CASE(L1TUtmAlgorithm)
234  FETCH_PAYLOAD_CASE(L1TUtmBin)
235  FETCH_PAYLOAD_CASE(L1TUtmCondition)
236  FETCH_PAYLOAD_CASE(L1TUtmCut)
237  FETCH_PAYLOAD_CASE(L1TUtmCutValue)
238  FETCH_PAYLOAD_CASE(L1TUtmObject)
239  FETCH_PAYLOAD_CASE(L1TUtmScale)
240  FETCH_PAYLOAD_CASE(L1TUtmTriggerMenu)
241  FETCH_PAYLOAD_CASE(L1TGlobalParameters)
242  FETCH_PAYLOAD_CASE(L1TriggerKey)
243  FETCH_PAYLOAD_CASE(L1TriggerKeyList)
244  FETCH_PAYLOAD_CASE(lumi::LumiSectionData)
245  FETCH_PAYLOAD_CASE(MixingModuleConfig)
246  FETCH_PAYLOAD_CASE(MuScleFitDBobject)
247  FETCH_PAYLOAD_CASE(DYTThrObject)
248  FETCH_PAYLOAD_CASE(DYTParamObject)
249  FETCH_PAYLOAD_CASE(PhysicsTools::Calibration::MVAComputerContainer)
250  FETCH_PAYLOAD_CASE(PhysicsTGraphPayload)
251  FETCH_PAYLOAD_CASE(PhysicsTFormulaPayload)
252  FETCH_PAYLOAD_CASE(PCaloGeometry)
253  FETCH_PAYLOAD_CASE(HcalParameters)
254  FETCH_PAYLOAD_CASE(PGeometricDet)
255  FETCH_PAYLOAD_CASE(PTrackerParameters)
256  FETCH_PAYLOAD_CASE(PTrackerAdditionalParametersPerDet)
257  FETCH_PAYLOAD_CASE(PHGCalParameters)
258  //FETCH_PAYLOAD_CASE( PerformancePayload )
259  FETCH_PAYLOAD_CASE(PerformancePayloadFromTable)
260  FETCH_PAYLOAD_CASE(PerformancePayloadFromTFormula)
261  FETCH_PAYLOAD_CASE(PerformancePayloadFromBinnedTFormula)
262  FETCH_PAYLOAD_CASE(PerformanceWorkingPoint)
263  FETCH_PAYLOAD_CASE(PhysicsTools::Calibration::HistogramD3D)
264  FETCH_PAYLOAD_CASE(QGLikelihoodCategory)
265  FETCH_PAYLOAD_CASE(QGLikelihoodObject)
266  FETCH_PAYLOAD_CASE(QGLikelihoodSystematicsObject)
267  FETCH_PAYLOAD_CASE(RPCEMap)
268  FETCH_PAYLOAD_CASE(RPCClusterSize)
269  FETCH_PAYLOAD_CASE(RPCStripNoises)
270  FETCH_PAYLOAD_CASE(RPCObFebmap)
271  FETCH_PAYLOAD_CASE(RPCObGas)
272  FETCH_PAYLOAD_CASE(RPCObImon)
273  FETCH_PAYLOAD_CASE(RPCObGasMix)
274  FETCH_PAYLOAD_CASE(RPCObPVSSmap)
275  FETCH_PAYLOAD_CASE(RPCObStatus)
276  FETCH_PAYLOAD_CASE(RPCObTemp)
277  FETCH_PAYLOAD_CASE(RPCObUXC)
278  FETCH_PAYLOAD_CASE(RPCObVmon)
279  FETCH_PAYLOAD_CASE(RPCLBLinkMap)
280  FETCH_PAYLOAD_CASE(RPCDCCLinkMap)
281  FETCH_PAYLOAD_CASE(RPCAMCLinkMap)
282  FETCH_PAYLOAD_CASE(RPFlatParams)
283  FETCH_PAYLOAD_CASE(RecoIdealGeometry)
284  FETCH_PAYLOAD_CASE(RunInfo)
285  FETCH_PAYLOAD_CASE(SimBeamSpotObjects)
286  FETCH_PAYLOAD_CASE(SiPhase2OuterTrackerLorentzAngle)
287  FETCH_PAYLOAD_CASE(SiPixelCalibConfiguration)
288  FETCH_PAYLOAD_CASE(SiPixelCPEGenericErrorParm)
289  FETCH_PAYLOAD_CASE(SiPixelFedCablingMap)
290  FETCH_PAYLOAD_CASE(SiPixelGainCalibrationForHLT)
291  FETCH_PAYLOAD_CASE(SiPixelGainCalibrationOffline)
292  FETCH_PAYLOAD_CASE(SiPixelGenErrorDBObject)
293  FETCH_PAYLOAD_CASE(SiPixelLorentzAngle)
294  FETCH_PAYLOAD_CASE(SiPixelDynamicInefficiency)
295  FETCH_PAYLOAD_CASE(SiPixelQuality)
296  FETCH_PAYLOAD_CASE(SiPixelFEDChannelContainer)
297  FETCH_PAYLOAD_CASE(SiPixelQualityProbabilities)
298  FETCH_PAYLOAD_CASE(SiPixelTemplateDBObject)
299  FETCH_PAYLOAD_CASE(SiPixel2DTemplateDBObject)
300  FETCH_PAYLOAD_CASE(SiPixelVCal)
301  FETCH_PAYLOAD_CASE(SiStripApvGain)
302  FETCH_PAYLOAD_CASE(SiStripApvSimulationParameters)
303  FETCH_PAYLOAD_CASE(SiStripBackPlaneCorrection)
304  FETCH_PAYLOAD_CASE(SiStripBadStrip)
305  FETCH_PAYLOAD_CASE(SiStripConfObject)
306  FETCH_PAYLOAD_CASE(SiStripDetVOff)
307  FETCH_PAYLOAD_CASE(SiStripFedCabling)
308  FETCH_PAYLOAD_CASE(SiStripLatency)
309  FETCH_PAYLOAD_CASE(SiStripLorentzAngle)
310  FETCH_PAYLOAD_CASE(SiStripNoises)
311  FETCH_PAYLOAD_CASE(SiStripPedestals)
312  FETCH_PAYLOAD_CASE(SiStripThreshold)
313  FETCH_PAYLOAD_CASE(DTCELinkId)
314  FETCH_PAYLOAD_CASE(TotemAnalysisMask)
315  FETCH_PAYLOAD_CASE(TotemDAQMapping)
316  FETCH_PAYLOAD_CASE(TrackerDetToDTCELinkCablingMap)
317  FETCH_PAYLOAD_CASE(TrackProbabilityCalibration)
318  FETCH_PAYLOAD_CASE(cond::BaseKeyed)
319  FETCH_PAYLOAD_CASE(ESCondObjectContainer<ESChannelStatusCode>)
320  FETCH_PAYLOAD_CASE(ESCondObjectContainer<ESPedestal>)
321  FETCH_PAYLOAD_CASE(ESCondObjectContainer<float>)
322  FETCH_PAYLOAD_CASE(EcalCondObjectContainer<EcalChannelStatusCode>)
323  FETCH_PAYLOAD_CASE(EcalCondObjectContainer<EcalMGPAGainRatio>)
324  FETCH_PAYLOAD_CASE(EcalCondObjectContainer<EcalTPGPedestal>)
325  FETCH_PAYLOAD_CASE(EcalCondObjectContainer<EcalXtalGroupId>)
326  FETCH_PAYLOAD_CASE(EcalCondObjectContainer<float>)
327  FETCH_PAYLOAD_CASE(MagFieldConfig)
328  FETCH_PAYLOAD_CASE(L1TGlobalPrescalesVetos)
329  FETCH_PAYLOAD_CASE(L1TGlobalPrescalesVetosFract)
330 
331  //
332  if (payloadTypeName == "PhysicsTools::Calibration::Histogram3D<double,double,double,double>") {
333  payloadPtr = deserialize<PhysicsTools::Calibration::Histogram3D<double, double, double, double> >(
334  payloadTypeName, data, streamerInfo);
335  match = true;
336  }
337  if (payloadTypeName == "PhysicsTools::Calibration::Histogram2D<double,double,double>") {
338  payloadPtr = deserialize<PhysicsTools::Calibration::Histogram2D<double, double, double> >(
339  payloadTypeName, data, streamerInfo);
340  match = true;
341  }
342  if (payloadTypeName == "std::vector<unsignedlonglong,std::allocator<unsignedlonglong>>") {
343  payloadPtr = deserialize<std::vector<unsigned long long> >(payloadTypeName, data, streamerInfo);
344  match = true;
345  }
346 
347  if (!match)
348  throwException("Payload type \"" + payloadTypeName + "\" is unknown.", "fetch");
349  return std::make_pair(payloadTypeName, payloadPtr);
350  }
TotemAnalysisMask
Channel-mask mapping.
Definition: TotemAnalysisMask.h:41
ESGain
Definition: ESGain.h:7
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
FETCH_PAYLOAD_CASE
#define FETCH_PAYLOAD_CASE(TYPENAME)
Definition: CondDBFetch.cc:3
DTT0
Definition: DTT0.h:48
QGLikelihoodObject
QGLikelihoodObject containing valid range and entries with category and histogram (mean is not used a...
Definition: QGLikelihoodObject.h:22
TotemDAQMapping
The mapping between FramePosition and VFATInfo.
Definition: TotemDAQMapping.h:45
CTPPSPixelAnalysisMask
Channel-mask mapping.
Definition: CTPPSPixelAnalysisMask.h:35
QGLikelihoodCategory
Category structure: ranges associated with QGLikelihood histograms.
Definition: QGLikelihoodObject.h:9
SiStripFedCabling
Contains cabling info at the device level, including DetId, APV pair numbers, hardware addresses...
Definition: SiStripFedCabling.h:25
CTPPSRPAlignmentCorrectionsData
Container for CTPPS RP alignment corrections. The corrections are stored on two levels - RP and senso...
Definition: CTPPSRPAlignmentCorrectionsData.h:25
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:80
match
std::pair< typename Association::data_type::first_type, double > match(Reference key, Association association, bool bestMatchByMaxValue)
Generic matching function.
Definition: Utils.h:10
QGLikelihoodSystematicsObject
QGLikelihoodSystematicsObject containing the parameters for the systematic smearing.
Definition: QGLikelihoodObject.h:38
LHCOpticalFunctionsSetCollection
Collection of optical functions for two crossing angle values and various scoring planes...
Definition: LHCOpticalFunctionsSetCollection.h:16
cond::persistency::throwException
void throwException(const std::string &message, const std::string &methodName)
Definition: Exception.cc:12
CTPPSPixelDAQMapping
The mapping between FramePosition and ROCInfo.
Definition: CTPPSPixelDAQMapping.h:41

◆ fullyQualifiedTag()

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

Definition at line 8 of file GTProxy.cc.

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

Referenced by CondDBESSource::CondDBESSource().

8  {
9  if (connectionString.empty())
10  return tag;
11  return tag + "@[" + connectionString + "]";
12  }
makeGlobalPositionRcd_cfg.tag
tag
Definition: makeGlobalPositionRcd_cfg.py:6
l1RCTOmdsFedVectorProducer_cfi.connectionString
connectionString
Definition: l1RCTOmdsFedVectorProducer_cfi.py:4

◆ get_timestamp()

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

Definition at line 100 of file Logger.cc.

References submitPVValidationJobs::now, and print_timestamp().

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

100  {
101  auto now = boost::posix_time::microsec_clock::universal_time();
102  return print_timestamp(now);
103  }
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

◆ get_timestamp_for_filename()

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

Definition at line 104 of file Logger.cc.

References submitPVValidationJobs::now, and print_timestamp().

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

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

◆ 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.

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

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

41  {
42  if (connectionString.empty())
43  cond::throwException("The connection string is empty.", "getConnectionParams");
44  std::string protocol = getConnectionProtocol(connectionString);
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") {
91  finalConn = parseFipConnectionString(connectionString);
92  }
93  return std::make_pair(finalConn, refreshConn);
94  }
cond::persistency::getConnectionProtocol
std::string getConnectionProtocol(const std::string &connectionString)
Definition: Utils.h:86
cond::persistency::parseFipConnectionString
std::string parseFipConnectionString(const std::string &fipConnect)
Definition: DbConnectionString.cc:27
edm::SiteLocalConfig::lookupCalibConnect
virtual std::string const lookupCalibConnect(std::string const &input) const =0
trigger::size_type
uint16_t size_type
Definition: TriggerTypeDefs.h:18
cond::throwException
void throwException(const std::string &message, const std::string &methodName)
Definition: Exception.cc:18
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
edm::Service::isAvailable
bool isAvailable() const
Definition: Service.h:40
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
l1RCTOmdsFedVectorProducer_cfi.connectionString
connectionString
Definition: l1RCTOmdsFedVectorProducer_cfi.py:4
cond::persistency::countslash
unsigned int countslash(const std::string &input)
Definition: DbConnectionString.cc:13

◆ getConnectionProtocol()

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

Definition at line 86 of file Utils.h.

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

Referenced by getConnectionParams(), and parseConnectionString().

86  {
87  size_t techEnd = connectionString.find(':');
88  if (techEnd == std::string::npos)
89  throwException("Could not resolve the connection protocol on " + connectionString + ".",
90  "getConnectionProtocol");
91  std::string technology = connectionString.substr(0, techEnd);
92  return technology;
93  }
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
cond::persistency::throwException
void throwException(const std::string &message, const std::string &methodName)
Definition: Exception.cc:12
l1RCTOmdsFedVectorProducer_cfi.connectionString
connectionString
Definition: l1RCTOmdsFedVectorProducer_cfi.py:4

◆ 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.

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

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

43  {
44  cond::Hash payloadId("");
45  bool newInsert = false;
46  bool match = false;
47  if (inputPtr) {
48  IMPORT_PAYLOAD_CASE(std::string)
49  IMPORT_PAYLOAD_CASE(std::vector<unsigned long long>)
50  IMPORT_PAYLOAD_CASE(AlCaRecoTriggerBits)
51  IMPORT_PAYLOAD_CASE(AlignmentErrors)
52  IMPORT_PAYLOAD_CASE(AlignmentErrorsExtended)
53  IMPORT_PAYLOAD_CASE(AlignmentSurfaceDeformations)
54  IMPORT_PAYLOAD_CASE(Alignments)
55  IMPORT_PAYLOAD_CASE(AlignPCLThresholds)
56  IMPORT_PAYLOAD_CASE(AlignPCLThresholdsHG)
57  IMPORT_PAYLOAD_CASE(BeamSpotObjects)
58  IMPORT_PAYLOAD_CASE(BeamSpotOnlineObjects)
59  IMPORT_PAYLOAD_CASE(CSCBadChambers)
60  IMPORT_PAYLOAD_CASE(CSCBadStrips)
61  IMPORT_PAYLOAD_CASE(CSCBadWires)
62  IMPORT_PAYLOAD_CASE(CSCChamberIndex)
63  IMPORT_PAYLOAD_CASE(CSCChamberMap)
64  IMPORT_PAYLOAD_CASE(CSCChamberTimeCorrections)
65  IMPORT_PAYLOAD_CASE(CSCCrateMap)
66  IMPORT_PAYLOAD_CASE(CSCDBChipSpeedCorrection)
67  IMPORT_PAYLOAD_CASE(CSCDBCrosstalk)
68  IMPORT_PAYLOAD_CASE(CSCDBGains)
69  IMPORT_PAYLOAD_CASE(CSCDBGasGainCorrection)
70  IMPORT_PAYLOAD_CASE(CSCDBL1TPParameters)
71  IMPORT_PAYLOAD_CASE(CSCDBNoiseMatrix)
72  IMPORT_PAYLOAD_CASE(CSCDBPedestals)
73  IMPORT_PAYLOAD_CASE(CSCDDUMap)
74  IMPORT_PAYLOAD_CASE(CSCL1TPParameters)
75  IMPORT_PAYLOAD_CASE(CSCRecoDigiParameters)
76  IMPORT_PAYLOAD_CASE(CTPPSPixelDAQMapping)
77  IMPORT_PAYLOAD_CASE(CTPPSPixelAnalysisMask)
78  IMPORT_PAYLOAD_CASE(CTPPSPixelGainCalibrations)
79  IMPORT_PAYLOAD_CASE(CTPPSRPAlignmentCorrectionsData)
80  IMPORT_PAYLOAD_CASE(PPSAlignmentConfiguration)
81  IMPORT_PAYLOAD_CASE(PPSAssociationCuts)
82  IMPORT_PAYLOAD_CASE(LHCOpticalFunctionsSetCollection)
83  IMPORT_PAYLOAD_CASE(CastorChannelQuality)
84  IMPORT_PAYLOAD_CASE(CastorElectronicsMap)
85  IMPORT_PAYLOAD_CASE(CastorGainWidths)
86  IMPORT_PAYLOAD_CASE(CastorGains)
87  IMPORT_PAYLOAD_CASE(CastorPedestalWidths)
88  IMPORT_PAYLOAD_CASE(CastorPedestals)
89  IMPORT_PAYLOAD_CASE(CastorQIEData)
90  IMPORT_PAYLOAD_CASE(CastorRecoParams)
91  IMPORT_PAYLOAD_CASE(CastorSaturationCorrs)
92  IMPORT_PAYLOAD_CASE(CentralityTable)
93  IMPORT_PAYLOAD_CASE(DTCCBConfig)
94  IMPORT_PAYLOAD_CASE(DTDeadFlag)
95  IMPORT_PAYLOAD_CASE(DTHVStatus)
96  IMPORT_PAYLOAD_CASE(DTKeyedConfig)
97  IMPORT_PAYLOAD_CASE(DTLVStatus)
98  IMPORT_PAYLOAD_CASE(DTMtime)
99  IMPORT_PAYLOAD_CASE(DTReadOutMapping)
100  IMPORT_PAYLOAD_CASE(DTRecoConditions)
101  IMPORT_PAYLOAD_CASE(DTRecoUncertainties)
102  IMPORT_PAYLOAD_CASE(DTStatusFlag)
103  IMPORT_PAYLOAD_CASE(DTT0)
104  IMPORT_PAYLOAD_CASE(DTTPGParameters)
105  IMPORT_PAYLOAD_CASE(DTTtrig)
106  IMPORT_PAYLOAD_CASE(DropBoxMetadata)
107  IMPORT_PAYLOAD_CASE(ESChannelStatus)
108  IMPORT_PAYLOAD_CASE(ESEEIntercalibConstants)
109  IMPORT_PAYLOAD_CASE(ESFloatCondObjectContainer)
110  IMPORT_PAYLOAD_CASE(ESGain)
111  IMPORT_PAYLOAD_CASE(ESMIPToGeVConstant)
112  IMPORT_PAYLOAD_CASE(ESMissingEnergyCalibration)
113  IMPORT_PAYLOAD_CASE(ESPedestals)
114  IMPORT_PAYLOAD_CASE(ESRecHitRatioCuts)
115  IMPORT_PAYLOAD_CASE(ESThresholds)
116  IMPORT_PAYLOAD_CASE(ESTimeSampleWeights)
117  IMPORT_PAYLOAD_CASE(EcalADCToGeVConstant)
118  IMPORT_PAYLOAD_CASE(EcalChannelStatus)
119  IMPORT_PAYLOAD_CASE(EcalClusterEnergyCorrectionObjectSpecificParameters)
120  IMPORT_PAYLOAD_CASE(EcalDAQTowerStatus)
121  IMPORT_PAYLOAD_CASE(EcalDCSTowerStatus)
122  IMPORT_PAYLOAD_CASE(EcalDQMChannelStatus)
123  IMPORT_PAYLOAD_CASE(EcalDQMTowerStatus)
124  IMPORT_PAYLOAD_CASE(EcalFloatCondObjectContainer)
125  IMPORT_PAYLOAD_CASE(EcalFunParams)
126  IMPORT_PAYLOAD_CASE(EcalGainRatios)
127  IMPORT_PAYLOAD_CASE(EcalLaserAPDPNRatios)
128  IMPORT_PAYLOAD_CASE(EcalMappingElectronics)
129  IMPORT_PAYLOAD_CASE(EcalCondObjectContainer<EcalMappingElement>)
130  IMPORT_PAYLOAD_CASE(EcalCondObjectContainer<EcalPedestal>)
131  IMPORT_PAYLOAD_CASE(EcalCondObjectContainer<EcalTPGLinearizationConstant>)
132  IMPORT_PAYLOAD_CASE(EcalCondObjectContainer<EcalDQMStatusCode>)
133  IMPORT_PAYLOAD_CASE(EcalCondObjectContainer<EcalTPGCrystalStatusCode>)
134  IMPORT_PAYLOAD_CASE(EcalCondTowerObjectContainer<EcalDAQStatusCode>)
135  IMPORT_PAYLOAD_CASE(EcalCondTowerObjectContainer<EcalChannelStatusCode>)
136  IMPORT_PAYLOAD_CASE(EcalCondTowerObjectContainer<EcalDQMStatusCode>)
137  IMPORT_PAYLOAD_CASE(EcalPedestals)
138  IMPORT_PAYLOAD_CASE(EcalSRSettings)
139  IMPORT_PAYLOAD_CASE(EcalSampleMask)
140  IMPORT_PAYLOAD_CASE(EcalTBWeights)
141  IMPORT_PAYLOAD_CASE(EcalTPGCrystalStatus)
142  IMPORT_PAYLOAD_CASE(EcalTPGFineGrainEBGroup)
143  IMPORT_PAYLOAD_CASE(EcalTPGFineGrainEBIdMap)
144  IMPORT_PAYLOAD_CASE(EcalTPGFineGrainStripEE)
145  IMPORT_PAYLOAD_CASE(EcalTPGFineGrainTowerEE)
146  IMPORT_PAYLOAD_CASE(EcalTPGLinearizationConst)
147  IMPORT_PAYLOAD_CASE(EcalTPGLutGroup)
148  IMPORT_PAYLOAD_CASE(EcalTPGLutIdMap)
149  IMPORT_PAYLOAD_CASE(EcalTPGPedestals)
150  IMPORT_PAYLOAD_CASE(EcalTPGPhysicsConst)
151  IMPORT_PAYLOAD_CASE(EcalTPGSlidingWindow)
152  IMPORT_PAYLOAD_CASE(EcalTPGSpike)
153  IMPORT_PAYLOAD_CASE(EcalTPGStripStatus)
154  IMPORT_PAYLOAD_CASE(EcalTPGTowerStatus)
155  IMPORT_PAYLOAD_CASE(EcalTPGWeightGroup)
156  IMPORT_PAYLOAD_CASE(EcalTPGWeightIdMap)
157  IMPORT_PAYLOAD_CASE(EcalTimeBiasCorrections)
158  IMPORT_PAYLOAD_CASE(EcalTimeOffsetConstant)
159  IMPORT_PAYLOAD_CASE(EcalTimeDependentCorrections)
160  IMPORT_PAYLOAD_CASE(EcalWeightXtalGroups)
161  IMPORT_PAYLOAD_CASE(EcalSamplesCorrelation)
162  IMPORT_PAYLOAD_CASE(EcalCondObjectContainer<EcalPulseShape>)
163  IMPORT_PAYLOAD_CASE(EcalPulseShape)
164  IMPORT_PAYLOAD_CASE(EcalCondObjectContainer<EcalPulseCovariance>)
165  IMPORT_PAYLOAD_CASE(EcalPulseCovariance)
166  IMPORT_PAYLOAD_CASE(EcalCondObjectContainer<EcalPulseSymmCovariance>)
167  IMPORT_PAYLOAD_CASE(EcalPulseSymmCovariance)
168  IMPORT_PAYLOAD_CASE(EcalEBPhase2TPGAmplWeightIdMap)
169  IMPORT_PAYLOAD_CASE(EcalEBPhase2TPGAmplWeights)
170  IMPORT_PAYLOAD_CASE(EcalEBPhase2TPGTimeWeightIdMap)
171  IMPORT_PAYLOAD_CASE(EcalEBPhase2TPGTimeWeights)
172  IMPORT_PAYLOAD_CASE(EcalEBPhase2TPGPedestal)
173  IMPORT_PAYLOAD_CASE(EcalEBPhase2TPGLinearizationConstant)
174  IMPORT_PAYLOAD_CASE(FileBlob)
175  IMPORT_PAYLOAD_CASE(GBRForest)
176  IMPORT_PAYLOAD_CASE(GBRForestD)
177  IMPORT_PAYLOAD_CASE(HBHENegativeEFilter)
178  IMPORT_PAYLOAD_CASE(HFPhase1PMTParams)
179  IMPORT_PAYLOAD_CASE(HcalChannelQuality)
180  IMPORT_PAYLOAD_CASE(HcalDcsValues)
181  IMPORT_PAYLOAD_CASE(HcalElectronicsMap)
182  IMPORT_PAYLOAD_CASE(HcalFlagHFDigiTimeParams)
183  IMPORT_PAYLOAD_CASE(HcalFrontEndMap)
184  IMPORT_PAYLOAD_CASE(HcalGains)
185  IMPORT_PAYLOAD_CASE(HcalGainWidths)
186  IMPORT_PAYLOAD_CASE(HcalL1TriggerObjects)
187  IMPORT_PAYLOAD_CASE(HcalLUTCorrs)
188  IMPORT_PAYLOAD_CASE(HcalLongRecoParams)
189  IMPORT_PAYLOAD_CASE(HcalZDCLowGainFractions)
190  IMPORT_PAYLOAD_CASE(HcalLutMetadata)
191  IMPORT_PAYLOAD_CASE(HcalMCParams)
192  IMPORT_PAYLOAD_CASE(HcalPFCorrs)
193  IMPORT_PAYLOAD_CASE(HcalPFCuts)
194  IMPORT_PAYLOAD_CASE(HcalPedestalWidths)
195  IMPORT_PAYLOAD_CASE(HcalPedestals)
196  IMPORT_PAYLOAD_CASE(HcalQIEData)
197  IMPORT_PAYLOAD_CASE(HcalRecoParams)
198  IMPORT_PAYLOAD_CASE(HcalRespCorrs)
199  IMPORT_PAYLOAD_CASE(HcalSiPMCharacteristics)
200  IMPORT_PAYLOAD_CASE(HcalSiPMParameters)
201  IMPORT_PAYLOAD_CASE(HcalTimeCorrs)
202  IMPORT_PAYLOAD_CASE(HcalTPChannelParameters)
203  IMPORT_PAYLOAD_CASE(HcalTPParameters)
204  IMPORT_PAYLOAD_CASE(HcalZSThresholds)
205  IMPORT_PAYLOAD_CASE(HcalInterpolatedPulseColl)
206  IMPORT_PAYLOAD_CASE(JetCorrectorParametersCollection)
207  IMPORT_PAYLOAD_CASE(JME::JetResolutionObject)
208  IMPORT_PAYLOAD_CASE(METCorrectorParametersCollection)
209  IMPORT_PAYLOAD_CASE(MEtXYcorrectParametersCollection)
210  IMPORT_PAYLOAD_CASE(L1CaloEcalScale)
211  IMPORT_PAYLOAD_CASE(L1CaloEtScale)
212  IMPORT_PAYLOAD_CASE(L1CaloGeometry)
213  IMPORT_PAYLOAD_CASE(L1CaloHcalScale)
214  IMPORT_PAYLOAD_CASE(L1GctChannelMask)
215  IMPORT_PAYLOAD_CASE(L1GctJetFinderParams)
216  IMPORT_PAYLOAD_CASE(L1GtBoardMaps)
217  IMPORT_PAYLOAD_CASE(L1GtParameters)
218  IMPORT_PAYLOAD_CASE(L1GtPrescaleFactors)
219  IMPORT_PAYLOAD_CASE(L1GtPsbSetup)
220  IMPORT_PAYLOAD_CASE(L1GtStableParameters)
221  IMPORT_PAYLOAD_CASE(L1GtTriggerMask)
222  IMPORT_PAYLOAD_CASE(L1GtTriggerMenu)
223  IMPORT_PAYLOAD_CASE(L1MuCSCPtLut)
224  IMPORT_PAYLOAD_CASE(L1MuCSCTFAlignment)
225  IMPORT_PAYLOAD_CASE(L1MuCSCTFConfiguration)
226  IMPORT_PAYLOAD_CASE(L1MuDTEtaPatternLut)
227  IMPORT_PAYLOAD_CASE(L1MuDTExtLut)
228  IMPORT_PAYLOAD_CASE(L1MuDTPhiLut)
229  IMPORT_PAYLOAD_CASE(L1MuDTPtaLut)
230  IMPORT_PAYLOAD_CASE(L1MuDTQualPatternLut)
231  IMPORT_PAYLOAD_CASE(L1MuDTTFMasks)
232  IMPORT_PAYLOAD_CASE(L1MuDTTFParameters)
233  IMPORT_PAYLOAD_CASE(L1MuGMTChannelMask)
234  IMPORT_PAYLOAD_CASE(L1MuGMTParameters)
235  IMPORT_PAYLOAD_CASE(L1MuGMTScales)
236  IMPORT_PAYLOAD_CASE(L1MuTriggerPtScale)
237  IMPORT_PAYLOAD_CASE(L1MuTriggerScales)
238  IMPORT_PAYLOAD_CASE(L1RCTChannelMask)
239  IMPORT_PAYLOAD_CASE(L1RCTNoisyChannelMask)
240  IMPORT_PAYLOAD_CASE(L1RCTParameters)
241  IMPORT_PAYLOAD_CASE(L1RPCBxOrConfig)
242  IMPORT_PAYLOAD_CASE(L1RPCConeDefinition)
243  IMPORT_PAYLOAD_CASE(L1RPCConfig)
244  IMPORT_PAYLOAD_CASE(L1RPCHsbConfig)
245  IMPORT_PAYLOAD_CASE(L1RPCHwConfig)
246  IMPORT_PAYLOAD_CASE(l1t::CaloParams)
247  IMPORT_PAYLOAD_CASE(l1t::CaloConfig)
248  IMPORT_PAYLOAD_CASE(L1TMuonBarrelParams)
249  IMPORT_PAYLOAD_CASE(L1TMuonGlobalParams)
250  IMPORT_PAYLOAD_CASE(L1TMuonOverlapParams)
251  IMPORT_PAYLOAD_CASE(L1TUtmAlgorithm)
252  IMPORT_PAYLOAD_CASE(L1TUtmBin)
253  IMPORT_PAYLOAD_CASE(L1TUtmCondition)
254  IMPORT_PAYLOAD_CASE(L1TUtmCut)
255  IMPORT_PAYLOAD_CASE(L1TUtmCutValue)
256  IMPORT_PAYLOAD_CASE(L1TUtmObject)
257  IMPORT_PAYLOAD_CASE(L1TUtmScale)
258  IMPORT_PAYLOAD_CASE(L1TUtmTriggerMenu)
259  IMPORT_PAYLOAD_CASE(L1TGlobalParameters)
260  IMPORT_PAYLOAD_CASE(L1TriggerKey)
261  IMPORT_PAYLOAD_CASE(MagFieldConfig)
262  if (inputTypeName == "L1TriggerKeyList") {
263  match = true;
264  throwException("Import of \"L1TriggerKeyList\" type payloads is not supported.", "import");
265  }
266  //IMPORT_PAYLOAD_CASE( L1TriggerKeyList )
267  IMPORT_PAYLOAD_CASE(lumi::LumiSectionData)
268  IMPORT_PAYLOAD_CASE(MixingModuleConfig)
269  IMPORT_PAYLOAD_CASE(MuScleFitDBobject)
270  IMPORT_PAYLOAD_CASE(DYTThrObject)
271  IMPORT_PAYLOAD_CASE(DYTParamObject)
272  IMPORT_PAYLOAD_CASE(OOTPileupCorrectionBuffer)
273  IMPORT_PAYLOAD_CASE(StorableDoubleMap<AbsOOTPileupCorrection>)
274  IMPORT_PAYLOAD_CASE(PhysicsTools::Calibration::MVAComputerContainer)
275  IMPORT_PAYLOAD_CASE(PCaloGeometry)
276  IMPORT_PAYLOAD_CASE(HcalParameters)
277  IMPORT_PAYLOAD_CASE(PGeometricDet)
278  IMPORT_PAYLOAD_CASE(PTrackerParameters)
279  IMPORT_PAYLOAD_CASE(PTrackerAdditionalParametersPerDet)
280  IMPORT_PAYLOAD_CASE(PHGCalParameters)
281  //IMPORT_PAYLOAD_CASE( PerformancePayload )
282  IMPORT_PAYLOAD_CASE(PerformancePayloadFromTable)
283  IMPORT_PAYLOAD_CASE(PerformancePayloadFromTFormula)
284  IMPORT_PAYLOAD_CASE(PerformancePayloadFromBinnedTFormula)
285  IMPORT_PAYLOAD_CASE(PerformanceWorkingPoint)
286  IMPORT_PAYLOAD_CASE(PhysicsTGraphPayload)
287  IMPORT_PAYLOAD_CASE(PhysicsTFormulaPayload)
288  IMPORT_PAYLOAD_CASE(PhysicsTools::Calibration::HistogramD3D)
289  IMPORT_PAYLOAD_CASE(PPSTimingCalibration)
290  IMPORT_PAYLOAD_CASE(QGLikelihoodCategory)
291  IMPORT_PAYLOAD_CASE(QGLikelihoodObject)
292  IMPORT_PAYLOAD_CASE(QGLikelihoodSystematicsObject)
293  IMPORT_PAYLOAD_CASE(RPCEMap)
294  IMPORT_PAYLOAD_CASE(RPCClusterSize)
295  IMPORT_PAYLOAD_CASE(RPCStripNoises)
296  IMPORT_PAYLOAD_CASE(RPCObFebmap)
297  IMPORT_PAYLOAD_CASE(RPCObGas)
298  IMPORT_PAYLOAD_CASE(RPCObImon)
299  IMPORT_PAYLOAD_CASE(RPCObGasMix)
300  IMPORT_PAYLOAD_CASE(RPCObPVSSmap)
301  IMPORT_PAYLOAD_CASE(RPCObStatus)
302  IMPORT_PAYLOAD_CASE(RPCObTemp)
303  IMPORT_PAYLOAD_CASE(RPCObUXC)
304  IMPORT_PAYLOAD_CASE(RPCObVmon)
305  IMPORT_PAYLOAD_CASE(RPCLBLinkMap)
306  IMPORT_PAYLOAD_CASE(RPCDCCLinkMap)
307  IMPORT_PAYLOAD_CASE(RPCAMCLinkMap)
308  IMPORT_PAYLOAD_CASE(RPFlatParams)
309  IMPORT_PAYLOAD_CASE(RecoIdealGeometry)
310  IMPORT_PAYLOAD_CASE(RunInfo)
311  IMPORT_PAYLOAD_CASE(SimBeamSpotObjects)
312  IMPORT_PAYLOAD_CASE(SiPhase2OuterTrackerLorentzAngle)
313  IMPORT_PAYLOAD_CASE(SiPixelCalibConfiguration)
314  IMPORT_PAYLOAD_CASE(SiPixelCPEGenericErrorParm)
315  IMPORT_PAYLOAD_CASE(SiPixelFedCablingMap)
316  IMPORT_PAYLOAD_CASE(SiPixelGainCalibrationForHLT)
317  IMPORT_PAYLOAD_CASE(SiPixelGainCalibrationOffline)
318  IMPORT_PAYLOAD_CASE(SiPixelGenErrorDBObject)
319  IMPORT_PAYLOAD_CASE(SiPixelLorentzAngle)
320  IMPORT_PAYLOAD_CASE(SiPixelDynamicInefficiency)
321  IMPORT_PAYLOAD_CASE(SiPixelQuality)
322  IMPORT_PAYLOAD_CASE(SiPixelFEDChannelContainer)
323  IMPORT_PAYLOAD_CASE(SiPixelQualityProbabilities)
324  IMPORT_PAYLOAD_CASE(SiPixelTemplateDBObject)
325  IMPORT_PAYLOAD_CASE(SiPixel2DTemplateDBObject)
326  IMPORT_PAYLOAD_CASE(SiPixelVCal)
327  IMPORT_PAYLOAD_CASE(SiStripApvGain)
328  IMPORT_PAYLOAD_CASE(SiStripApvSimulationParameters)
329  IMPORT_PAYLOAD_CASE(SiStripBadStrip)
330  IMPORT_PAYLOAD_CASE(SiStripBackPlaneCorrection)
331  IMPORT_PAYLOAD_CASE(SiStripConfObject)
332  IMPORT_PAYLOAD_CASE(SiStripDetVOff)
333  IMPORT_PAYLOAD_CASE(SiStripFedCabling)
334  IMPORT_PAYLOAD_CASE(SiStripLatency)
335  IMPORT_PAYLOAD_CASE(SiStripLorentzAngle)
336  IMPORT_PAYLOAD_CASE(SiStripNoises)
337  IMPORT_PAYLOAD_CASE(SiStripPedestals)
338  IMPORT_PAYLOAD_CASE(SiStripThreshold)
339  IMPORT_PAYLOAD_CASE(DTCELinkId)
340  IMPORT_PAYLOAD_CASE(TotemAnalysisMask)
341  IMPORT_PAYLOAD_CASE(TotemDAQMapping)
342  IMPORT_PAYLOAD_CASE(TrackerDetToDTCELinkCablingMap)
343  IMPORT_PAYLOAD_CASE(TrackProbabilityCalibration)
344  IMPORT_PAYLOAD_CASE(cond::BaseKeyed)
345  IMPORT_PAYLOAD_CASE(ESCondObjectContainer<ESChannelStatusCode>)
346  IMPORT_PAYLOAD_CASE(ESCondObjectContainer<ESPedestal>)
347  IMPORT_PAYLOAD_CASE(ESCondObjectContainer<float>)
348  IMPORT_PAYLOAD_CASE(EcalCondObjectContainer<EcalChannelStatusCode>)
349  IMPORT_PAYLOAD_CASE(EcalCondObjectContainer<EcalMGPAGainRatio>)
350  IMPORT_PAYLOAD_CASE(EcalCondObjectContainer<EcalTPGPedestal>)
351  IMPORT_PAYLOAD_CASE(EcalCondObjectContainer<EcalXtalGroupId>)
352  IMPORT_PAYLOAD_CASE(EcalCondObjectContainer<float>)
353  IMPORT_PAYLOAD_CASE(L1TGlobalPrescalesVetos)
354  IMPORT_PAYLOAD_CASE(L1TGlobalPrescalesVetosFract)
355  if (inputTypeName == "PhysicsTools::Calibration::Histogram3D<double,double,double,double>") {
356  match = true;
357  const PhysicsTools::Calibration::Histogram3D<double, double, double, double>& obj =
358  *static_cast<const PhysicsTools::Calibration::Histogram3D<double, double, double, double>*>(inputPtr);
359  payloadId = destination.storePayload(obj, boost::posix_time::microsec_clock::universal_time());
360  }
361  if (inputTypeName == "PhysicsTools::Calibration::Histogram2D<double,double,double>") {
362  match = true;
363  const PhysicsTools::Calibration::Histogram2D<double, double, double>& obj =
364  *static_cast<const PhysicsTools::Calibration::Histogram2D<double, double, double>*>(inputPtr);
365  payloadId = destination.storePayload(obj, boost::posix_time::microsec_clock::universal_time());
366  }
367  if (inputTypeName == "std::vector<unsignedlonglong,std::allocator<unsignedlonglong>>") {
368  match = true;
369  const std::vector<unsigned long long>& obj = *static_cast<const std::vector<unsigned long long>*>(inputPtr);
370  payloadId = destination.storePayload(obj, boost::posix_time::microsec_clock::universal_time());
371  }
372 
373  if (!match)
374  throwException("Payload type \"" + inputTypeName + "\" is unknown.", "import");
375  }
376  return payloadId;
377  }
TotemAnalysisMask
Channel-mask mapping.
Definition: TotemAnalysisMask.h:41
ESGain
Definition: ESGain.h:7
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
DTT0
Definition: DTT0.h:48
QGLikelihoodObject
QGLikelihoodObject containing valid range and entries with category and histogram (mean is not used a...
Definition: QGLikelihoodObject.h:22
TotemDAQMapping
The mapping between FramePosition and VFATInfo.
Definition: TotemDAQMapping.h:45
IMPORT_PAYLOAD_CASE
#define IMPORT_PAYLOAD_CASE(TYPENAME)
Definition: CondDBImport.cc:4
CTPPSPixelAnalysisMask
Channel-mask mapping.
Definition: CTPPSPixelAnalysisMask.h:35
cond::Hash
std::string Hash
Definition: Types.h:43
QGLikelihoodCategory
Category structure: ranges associated with QGLikelihood histograms.
Definition: QGLikelihoodObject.h:9
HLTMuonOfflineAnalyzer_cff.destination
destination
Definition: HLTMuonOfflineAnalyzer_cff.py:16
SiStripFedCabling
Contains cabling info at the device level, including DetId, APV pair numbers, hardware addresses...
Definition: SiStripFedCabling.h:25
CTPPSRPAlignmentCorrectionsData
Container for CTPPS RP alignment corrections. The corrections are stored on two levels - RP and senso...
Definition: CTPPSRPAlignmentCorrectionsData.h:25
match
std::pair< typename Association::data_type::first_type, double > match(Reference key, Association association, bool bestMatchByMaxValue)
Generic matching function.
Definition: Utils.h:10
QGLikelihoodSystematicsObject
QGLikelihoodSystematicsObject containing the parameters for the systematic smearing.
Definition: QGLikelihoodObject.h:38
LHCOpticalFunctionsSetCollection
Collection of optical functions for two crossing angle values and various scoring planes...
Definition: LHCOpticalFunctionsSetCollection.h:16
cond::persistency::throwException
void throwException(const std::string &message, const std::string &methodName)
Definition: Exception.cc:12
CTPPSPixelDAQMapping
The mapping between FramePosition and ROCInfo.
Definition: CTPPSPixelDAQMapping.h:41

◆ 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 39 of file CondDBTools.cc.

References cond::persistency::Session::connectionString(), gather_cfg::cout, cond::persistency::Session::createDatabase(), cond::persistency::Session::createIov(), makeListRunsInFiles::description, Calorimetry_cff::dp, cond::persistency::Session::editIov(), 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(), SiStripBadComponentsDQMServiceTemplate_cfg::since, optionsL1T::skip, RawToDigi_cff::sourceTag, cond::persistency::TransactionScope::start(), throwException(), cond::persistency::IOVEditor::timeType(), and cond::persistency::Session::transaction().

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

◆ importPayload()

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

Definition at line 12 of file CondDBTools.cc.

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

Referenced by importIovs().

15  {
16  if (reserialize) {
17  std::pair<std::string, std::shared_ptr<void> > readBackPayload = fetch(sourcePayloadId, sourceSession);
18  return import(sourceSession, sourcePayloadId, readBackPayload.first, readBackPayload.second.get(), destSession);
19  } else {
20  std::string payloadType("");
21  cond::Binary payloadData;
22  cond::Binary streamerInfoData;
23  if (!sourceSession.fetchPayloadData(sourcePayloadId, payloadType, payloadData, streamerInfoData)) {
24  cond::throwException("Payload with hash" + sourcePayloadId + " has not been found in the source database.",
25  "importPayload");
26  }
27  boost::posix_time::ptime now = boost::posix_time::microsec_clock::universal_time();
28  return destSession.storePayloadData(payloadType, std::make_pair(payloadData, streamerInfoData), now);
29  }
30  }
HLT_2023v12_cff.payloadType
payloadType
Definition: HLT_2023v12_cff.py:7394
cond::throwException
void throwException(const std::string &message, const std::string &methodName)
Definition: Exception.cc:18
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
cond::persistency::fetch
std::pair< std::string, std::shared_ptr< void > > fetch(const cond::Hash &payloadId, Session &session)
Definition: CondDBFetch.cc:352

◆ 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.

References f, and alignCSCRings::s.

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

181  {
182  return std::get<0>(f) < std::get<0>(s);
183  }
f
double f[11][100]
Definition: MuScleFitUtils.cc:78

◆ is_same_any() [1/2]

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

Definition at line 276 of file DbCore.h.

References relativeConstraints::value.

276  {
277  return std::is_same<T, Arg1>::value;
278  };

◆ is_same_any() [2/2]

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

Definition at line 281 of file DbCore.h.

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

◆ makeHash()

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

Definition at line 10 of file IOVSchema.cc.

References data, EVP_MD_CTX_free, EVP_MD_CTX_new, cond::hash, mps_fire::i, cms::openssl_init(), throwException(), and createJobs::tmp.

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

10  {
11  cms::openssl_init();
12  EVP_MD_CTX* mdctx = EVP_MD_CTX_new();
13  const EVP_MD* md = EVP_get_digestbyname("SHA1");
14  if (!EVP_DigestInit_ex(mdctx, md, nullptr)) {
15  throwException("SHA1 initialization error.", "IOVSchema::makeHash");
16  }
17  if (!EVP_DigestUpdate(mdctx, objectType.c_str(), objectType.size())) {
18  throwException("SHA1 processing error (1).", "IOVSchema::makeHash");
19  }
20  if (!EVP_DigestUpdate(mdctx, data.data(), data.size())) {
21  throwException("SHA1 processing error (2).", "IOVSchema::makeHash");
22  }
23  unsigned char hash[EVP_MAX_MD_SIZE];
24  unsigned int md_len = 0;
25  if (!EVP_DigestFinal_ex(mdctx, hash, &md_len)) {
26  throwException("SHA1 finalization error.", "IOVSchema::makeHash");
27  }
28  EVP_MD_CTX_free(mdctx);
29  char tmp[EVP_MAX_MD_SIZE * 2 + 1];
30  // re-write bytes in hex
31  if (md_len > 20) {
32  md_len = 20;
33  }
34  for (unsigned int i = 0; i < md_len; i++) {
35  ::sprintf(&tmp[i * 2], "%02x", hash[i]);
36  }
37  tmp[md_len * 2] = 0;
38  return tmp;
39  }
cms::openssl_init
void openssl_init()
Definition: openssl_init.cc:5
mps_fire.i
i
Definition: mps_fire.py:429
EVP_MD_CTX_free
#define EVP_MD_CTX_free
Definition: openssl_init.h:7
EVP_MD_CTX_new
#define EVP_MD_CTX_new
Definition: openssl_init.h:6
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:80
createJobs.tmp
tmp
align.sh
Definition: createJobs.py:716
cond::persistency::throwException
void throwException(const std::string &message, const std::string &methodName)
Definition: Exception.cc:12

◆ parseConnectionString()

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

Definition at line 95 of file Utils.h.

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

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

95  {
96  std::string protocol = getConnectionProtocol(connectionString);
97  std::string serviceName("");
98  std::string databaseName("");
99  if (protocol == "sqlite" || protocol == "sqlite_file" || protocol == "sqlite_fip") {
100  databaseName = connectionString.substr(protocol.size() + 1);
101  } else if (protocol == "oracle" || protocol == "frontier") {
102  size_t ptr = protocol.size() + 1;
103  if (connectionString.substr(ptr, 2) != "//")
104  throwException(
105  "Connection string " + connectionString + " is invalid format for technology \"" + protocol + "\".",
106  "parseConnectionString");
107  ptr += 2;
108  size_t serviceEnd = connectionString.find('/', ptr);
109  if (serviceEnd == std::string::npos)
110  throwException("Connection string " + connectionString + " is invalid.", "parseConnectionString");
111  serviceName = connectionString.substr(ptr, serviceEnd - ptr);
112  ptr = serviceEnd + 1;
113  databaseName = connectionString.substr(ptr);
114  } else
115  throwException("Technology " + protocol + " is not known.", "parseConnectionString");
116 
117  return std::make_tuple(protocol, serviceName, databaseName);
118  }
cond::persistency::getConnectionProtocol
std::string getConnectionProtocol(const std::string &connectionString)
Definition: Utils.h:86
serviceName
static const std::string serviceName
Definition: CredentialStore.cc:31
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
cond::persistency::throwException
void throwException(const std::string &message, const std::string &methodName)
Definition: Exception.cc:12
l1RCTOmdsFedVectorProducer_cfi.connectionString
connectionString
Definition: l1RCTOmdsFedVectorProducer_cfi.py:4

◆ parseFipConnectionString()

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

Definition at line 27 of file DbConnectionString.cc.

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

Referenced by getConnectionParams().

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  }
trigger::size_type
uint16_t size_type
Definition: TriggerTypeDefs.h:18
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
GlobalPosition_Frontier_DevDB_cff.connect
connect
Definition: GlobalPosition_Frontier_DevDB_cff.py:8

◆ parseTag()

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

Definition at line 14 of file GTProxy.cc.

References AlCaHLTBitMon_QueryRunRegistry::string, submitPVValidationJobs::t, and makeGlobalPositionRcd_cfg::tag.

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

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  }
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
makeGlobalPositionRcd_cfg.tag
tag
Definition: makeGlobalPositionRcd_cfg.py:6

◆ 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.

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

Referenced by get_timestamp(), and get_timestamp_for_filename().

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  }
f
double f[11][100]
Definition: MuScleFitUtils.cc:78

◆ search()

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

Definition at line 21 of file IOVProxy.cc.

References AlCaHLTBitMon_ParallelJobs::p, pfDeepBoostedJetPreprocessParams_cfi::upper_bound, and heppy_batch::val.

Referenced by dqm_interfaces.DirID::__eq__(), ValidationMatrix::add_to_blacklist(), L1TMuonBarrelKalmanAlgo::clean(), ValidationMatrix::do_comparisons_threaded(), DQMPFCandidateAnalyzer::dqmBeginRun(), METAnalyzer::dqmBeginRun(), AlignmentMonitorTemplate::event(), HcalIndexLookup::find(), cond::persistency::IOVArray::find(), cond::persistency::IOVProxy::getInterval(), ValidationMatrix::guess_blacklists(), ValidationMatrix::guess_params(), LumiSectionFilter< T >::process(), TauGenJetProducer::produce(), GEMDigiToRawModule::produce(), and duplicateReflexLibrarySearch::searchClassDefXml().

21  {
22  if (container.empty())
23  return container.end();
24  auto p = std::upper_bound(container.begin(), container.end(), val, IOVComp());
25  return (p != container.begin()) ? p - 1 : container.end();
26  }
pfDeepBoostedJetPreprocessParams_cfi.upper_bound
upper_bound
Definition: pfDeepBoostedJetPreprocessParams_cfi.py:16
heppy_batch.val
val
Definition: heppy_batch.py:351
AlCaHLTBitMon_ParallelJobs.p
def p
Definition: AlCaHLTBitMon_ParallelJobs.py:153

◆ 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.

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

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  }
cond::persistency::Exception
Base exception class for the object to relational access.
Definition: Exception.h:11
cond::serialize
std::pair< Binary, Binary > serialize(const T &payload)
Definition: Serialization.h:66
runTheMatrix.ret
ret
prodAgent to be discontinued
Definition: runTheMatrix.py:760
MillePedeFileConverter_cfg.e
e
Definition: MillePedeFileConverter_cfg.py:37
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
cond::Hash
std::string Hash
Definition: Types.h:43
jetsAK4_Puppi_cff.payload
payload
Definition: jetsAK4_Puppi_cff.py:17
cond::persistency::throwException
void throwException(const std::string &message, const std::string &methodName)
Definition: Exception.cc:12

◆ setTillToLastIov()

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

Definition at line 248 of file IOVProxy.cc.

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

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

248  {
249  if (endOfValidity < cond::time::MAX_VAL) {
250  if (target.since >= endOfValidity) {
251  target.clear();
252  } else {
253  target.till = endOfValidity;
254  }
255  } else {
256  target.till = cond::time::MAX_VAL;
257  }
258  }
cond::time::MAX_VAL
const Time_t MAX_VAL(std::numeric_limits< Time_t >::max())

◆ 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  };
value
Definition: value.py:1

◆ throwException()

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

Definition at line 12 of file Exception.cc.

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().

12  {
13  throw Exception(message, methodName);
14  }
Generated for CMSSW Reference Manual by doxygen 1.8.14