cond::persistency Namespace Reference

Namespaces
	GLOBAL_TAG
	GLOBAL_TAG_MAP
	IOV
	PAYLOAD
	RUN_INFO
	TAG
	TAG_LOG

Classes
struct	AttributeTypeName
struct	AttributeTypeName< boost::posix_time::ptime >
struct	AttributeTypeName< cond::Binary >
struct	AttributeTypeName< cond::SynchronizationType >
struct	AttributeTypeName< cond::TimeType >
class	BasePayloadProxy
class	BulkInserter
class	CondDBTransaction
class	CondGetter
class	ConnectionPool
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	Exception
	Base exception class for the object to relational access. More...
struct	GetFromRow
struct	GetFromRow< boost::posix_time::ptime >
struct	GetFromRow< cond::Binary >
struct	GetFromRow< cond::SynchronizationType >
struct	GetFromRow< cond::TimeType >
struct	GetFromRow< std::array< char, n > >
class	GTEditor
class	GTEditorData
class	GTProxy
class	GTProxyData
class	GTSchema
class	IGTMapTable
class	IGTSchema
class	IGTTable
class	IIOVSchema
class	IIOVTable
struct	IOVComp
class	IOVEditor
class	IOVEditorData
class	IOVProxy
class	IOVProxyData
struct	IOVRunComp
class	IOVSchema
struct	IOVTimeComp
class	IPayloadMigrationTable
class	IPayloadTable
class	IRunInfoSchema
class	IRunInfoTable
class	ITagLogTable
class	ITagMigrationTable
class	ITagTable
class	ITransaction
class	KeyList
class	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

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_column_description (coral::TableDescription &table, const std::string &columnName, size_t size=0, bool notNull=true)
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::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 >
bool	is_same_any ()
template<typename T , typename Arg1 , typename Arg2 , typename... Args>
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)
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)
template<typename T , typename P >
void	static_assert_is_same_decayed ()
void	throwException (const std::string &message, const std::string &methodName)

Enumeration Type Documentation

enum cond::persistency::DbAuthenticationSystem

Enumerator
UndefinedAuthentication
CondDbKey
CoralXMLFile

Definition at line 28 of file ConnectionPool.h.

{ UndefinedAuthentication=0,CondDbKey, CoralXMLFile };

Function Documentation

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

inline

Definition at line 116 of file Utils.h.

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

Referenced by CondDBESSource::CondDBESSource().

                                                                        {

      // leave the connection string unmodified for sqlite
      if( input.find("sqlite") == 0 || input.find("oracle") == 0) return input;

      //static const boost::regex trivial("oracle://(cms_orcon_adg|cms_orcoff_prep)/([_[:alnum:]]+?)");
      static const boost::regex short_frontier("frontier://([[:alnum:]]+?)/([_[:alnum:]]+?)");
      static const boost::regex long_frontier("frontier://((\\([-[:alnum:]]+?=[^\\)]+?\\))+)/([_[:alnum:]]+?)");
      static const boost::regex long_frontier_serverurl("\\(serverurl=[^\\)]+?/([[:alnum:]]+?)\\)");

      static const std::map<std::string, std::string> frontierMap = {
    {"PromptProd", "cms_orcon_adg"},
    {"FrontierProd", "cms_orcon_adg"},
    {"FrontierArc", "cms_orcon_adg"},
    {"FrontierOnProd", "cms_orcon_adg"},
    {"FrontierPrep", "cms_orcoff_prep"},
      };

      boost::smatch matches;

      static const std::string technology("oracle://");
      std::string service("");
      std::string account("");

      bool match = false;
      if (boost::regex_match(input, matches, short_frontier)){
    service = matches[1];
    account = matches[2];
    match = true;
      }
      
      if (boost::regex_match(input, matches, long_frontier)) {
    std::string frontier_config(matches[1]);
    boost::smatch matches2;
    if (not boost::regex_search(frontier_config, matches2, long_frontier_serverurl))
      throwException("No serverurl in matched long frontier","convertoToOracleConnection");
    service = matches2[1];
    account = matches[3];
    match = true;
      }

      if( !match ) throwException("Connection string "+input+" can't be converted to oracle connection.","convertoToOracleConnection");

      if( service == "FrontierArc" ){
    size_t len = account.size()-5;
    account = account.substr(0,len);
      }

      auto it = frontierMap.find( service );
      if( it == frontierMap.end() ) throwException("Connection string can't be converted.","convertoToOracleConnection");
      service = it->second; 

      return technology+service+"/"+account;
    }

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

References gather_cfg::cout, cond::persistency::Session::createIov(), cond::persistency::Session::editIov(), idDealer::editor, cond::persistency::IOVProxy::end(), cond::persistency::Session::existsIov(), cond::persistency::IOVProxy::find(), cond::persistency::IOVEditor::flush(), cond::persistency::IOVEditor::insert(), cond::persistency::IOVProxy::loadedSize(), AlCaHLTBitMon_ParallelJobs::p, cond::persistency::IOVProxy::payloadObjectType(), cond::persistency::IOVEditor::payloadType(), cond::persistency::Session::readIov(), cond::persistency::IOVEditor::setDescription(), cond::persistency::TransactionScope::start(), cond::persistency::IOVProxy::synchronizationType(), throwException(), cond::persistency::IOVEditor::timeType(), cond::persistency::IOVProxy::timeType(), and cond::persistency::Session::transaction().

                                        {
      persistency::TransactionScope ssc( session.transaction() );
      ssc.start( false );
      std::cout <<"    Loading source iov..."<<std::endl;
      persistency::IOVProxy p = session.readIov( sourceTag, true );
      if( p.loadedSize()==0 ) {
    std::cout <<"    Tag contains 0 iovs."<<std::endl; 
    return false;
      } else {
    std::cout <<"    Iov size:"<<p.loadedSize()<<" timeType:"<<p.timeType()<<" payloadObjectType=\""<<p.payloadObjectType()<<"\""<<std::endl;
      }

      auto iiov = p.find( sourceSince );
      if( iiov == p.end() ){
    std::cout <<"ERROR: No Iov valid found for target time "<<sourceSince<<std::endl;
    return false;
      }

      persistency::IOVEditor editor;
      if( session.existsIov( destTag ) ){
    if( !description.empty() ) std::cout <<"   INFO. Destination Tag "<<destTag<<" already exists. Provided description will be ignored."<<std::endl;
    editor = session.editIov( destTag );
    if( editor.timeType() != p.timeType() )
      throwException( "TimeType of the destination tag does not match with the source tag timeType.", "importIovs"); 
    if( editor.payloadType() != p.payloadObjectType() )
      throwException( "PayloadType of the destination tag does not match with the source tag payloadType.", "importIovs");
      } else {
    editor = session.createIov( p.payloadObjectType(), destTag, p.timeType(), p.synchronizationType() );
    if( description.empty() ) editor.setDescription( "Created copying iovs from tag "+sourceTag );
    else editor.setDescription( description );
      }

      editor.insert( destSince, (*iiov).payloadId );

      std::cout <<"    Flushing changes..."<<std::endl;
      editor.flush();
      ssc.commit();
      return true;
    }

unsigned int cond::persistency::countslash

(

const std::string &

input

)

Definition at line 13 of file DbConnectionString.cc.

References KineDebug3::count().

Referenced by getConnectionParams().

                                                      {
      unsigned int count = 0;
      std::string::size_type slashpos( 0 );
      while( slashpos != std::string::npos ) {
        slashpos = input.find('/', slashpos );
        if( slashpos != std::string::npos ) {
          ++count;
          // start next search after this word
          slashpos += 1;
        }
      }
      return count;
    }

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

References findQualityFiles::size.

                                                                                                                                                     {
    table.insertColumn( columnName, AttributeTypeName<T>()(), size );
    if( notNull ) table.setNotNullConstraint( columnName );
  }

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

Definition at line 326 of file CondDBFetch.cc.

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

Referenced by importPayload().

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

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.

                                                                                                                      {
      std::shared_ptr<void> payloadPtr;
      cond::Binary data;
      cond::Binary streamerInfo;
      std::string payloadTypeName;
      exists = session.fetchPayloadData( payloadId, payloadTypeName, data, streamerInfo );
      if( exists ) {
    return fetchOne(payloadTypeName, data, streamerInfo, payloadPtr );
      } else return std::make_pair( std::string(""), std::shared_ptr<void>() );
    }

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

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

Referenced by fetch(), and fetchIfExists().

                                                                                                                                                                                 {

      bool match = false;
      FETCH_PAYLOAD_CASE( std::string ) 
      FETCH_PAYLOAD_CASE( std::vector<unsigned long long> )
      FETCH_PAYLOAD_CASE( AlCaRecoTriggerBits )
      FETCH_PAYLOAD_CASE( AlignmentErrors )
      FETCH_PAYLOAD_CASE( AlignmentErrorsExtended )
      FETCH_PAYLOAD_CASE( AlignmentSurfaceDeformations )
      FETCH_PAYLOAD_CASE( Alignments )
      FETCH_PAYLOAD_CASE( AlignPCLThresholds )  
      FETCH_PAYLOAD_CASE( BeamSpotObjects )
      FETCH_PAYLOAD_CASE( CSCBadChambers )
      FETCH_PAYLOAD_CASE( CSCBadStrips )
      FETCH_PAYLOAD_CASE( CSCBadWires )
      FETCH_PAYLOAD_CASE( CSCChamberIndex )
      FETCH_PAYLOAD_CASE( CSCChamberMap )
      FETCH_PAYLOAD_CASE( CSCChamberTimeCorrections )
      FETCH_PAYLOAD_CASE( CSCCrateMap )
      FETCH_PAYLOAD_CASE( CSCDBChipSpeedCorrection )
      FETCH_PAYLOAD_CASE( CSCDBCrosstalk )
      FETCH_PAYLOAD_CASE( CSCDBGains )
      FETCH_PAYLOAD_CASE( CSCDBGasGainCorrection )
      FETCH_PAYLOAD_CASE( CSCDBL1TPParameters )
      FETCH_PAYLOAD_CASE( CSCDBNoiseMatrix )
      FETCH_PAYLOAD_CASE( CSCDBPedestals )
      FETCH_PAYLOAD_CASE( CSCDDUMap )
      FETCH_PAYLOAD_CASE( CSCL1TPParameters )
      FETCH_PAYLOAD_CASE( CSCRecoDigiParameters )
      FETCH_PAYLOAD_CASE( CTPPSPixelDAQMapping )
      FETCH_PAYLOAD_CASE( CTPPSPixelAnalysisMask )
      FETCH_PAYLOAD_CASE( CastorChannelQuality )
      FETCH_PAYLOAD_CASE( CastorElectronicsMap )
      FETCH_PAYLOAD_CASE( CastorGainWidths )
      FETCH_PAYLOAD_CASE( CastorGains )
      FETCH_PAYLOAD_CASE( CastorPedestalWidths )
      FETCH_PAYLOAD_CASE( CastorPedestals )
      FETCH_PAYLOAD_CASE( CastorQIEData )
      FETCH_PAYLOAD_CASE( CastorRecoParams )
      FETCH_PAYLOAD_CASE( CastorSaturationCorrs )
      FETCH_PAYLOAD_CASE( CentralityTable )
      FETCH_PAYLOAD_CASE( DTCCBConfig )
      FETCH_PAYLOAD_CASE( DTDeadFlag )
      FETCH_PAYLOAD_CASE( DTHVStatus )
      FETCH_PAYLOAD_CASE( DTKeyedConfig )
      FETCH_PAYLOAD_CASE( DTLVStatus )
      FETCH_PAYLOAD_CASE( DTMtime )
      FETCH_PAYLOAD_CASE( DTReadOutMapping )
      FETCH_PAYLOAD_CASE( DTRecoConditions )    
      FETCH_PAYLOAD_CASE( DTRecoUncertainties )
      FETCH_PAYLOAD_CASE( DTStatusFlag )
      FETCH_PAYLOAD_CASE( DTT0 )
      FETCH_PAYLOAD_CASE( DTTPGParameters )
      FETCH_PAYLOAD_CASE( DTTtrig )
      FETCH_PAYLOAD_CASE( DropBoxMetadata )
      FETCH_PAYLOAD_CASE( ESChannelStatus )
      FETCH_PAYLOAD_CASE( ESEEIntercalibConstants )
      FETCH_PAYLOAD_CASE( ESFloatCondObjectContainer )
      FETCH_PAYLOAD_CASE( ESGain )
      FETCH_PAYLOAD_CASE( ESMIPToGeVConstant )
      FETCH_PAYLOAD_CASE( ESMissingEnergyCalibration )
      FETCH_PAYLOAD_CASE( ESPedestals )
      FETCH_PAYLOAD_CASE( ESRecHitRatioCuts )
      FETCH_PAYLOAD_CASE( ESThresholds )
      FETCH_PAYLOAD_CASE( ESTimeSampleWeights )
      FETCH_PAYLOAD_CASE( EcalADCToGeVConstant )
      FETCH_PAYLOAD_CASE( EcalChannelStatus )
      FETCH_PAYLOAD_CASE( EcalClusterEnergyCorrectionObjectSpecificParameters )
      FETCH_PAYLOAD_CASE( EcalDAQTowerStatus )
      FETCH_PAYLOAD_CASE( EcalDCSTowerStatus )
      FETCH_PAYLOAD_CASE( EcalDQMChannelStatus )
      FETCH_PAYLOAD_CASE( EcalDQMTowerStatus )
      FETCH_PAYLOAD_CASE( EcalFloatCondObjectContainer )
      FETCH_PAYLOAD_CASE( EcalFunParams )
      FETCH_PAYLOAD_CASE( EcalGainRatios )
      FETCH_PAYLOAD_CASE( EcalLaserAPDPNRatios )
      FETCH_PAYLOAD_CASE( EcalMappingElectronics )
      FETCH_PAYLOAD_CASE( EcalCondObjectContainer<EcalMappingElement> )
      FETCH_PAYLOAD_CASE( EcalCondObjectContainer<EcalPedestal> )
      FETCH_PAYLOAD_CASE( EcalCondObjectContainer<EcalTPGLinearizationConstant> )
      FETCH_PAYLOAD_CASE( EcalCondObjectContainer<EcalDQMStatusCode> )
      FETCH_PAYLOAD_CASE( EcalCondObjectContainer<EcalTPGCrystalStatusCode> )
      FETCH_PAYLOAD_CASE( EcalCondTowerObjectContainer<EcalDAQStatusCode> )
      FETCH_PAYLOAD_CASE( EcalCondTowerObjectContainer<EcalChannelStatusCode> )
      FETCH_PAYLOAD_CASE( EcalCondTowerObjectContainer<EcalDQMStatusCode> )
      FETCH_PAYLOAD_CASE( EcalPedestals )
      FETCH_PAYLOAD_CASE( EcalSRSettings )
      FETCH_PAYLOAD_CASE( EcalSampleMask )
      FETCH_PAYLOAD_CASE( EcalTBWeights )
      FETCH_PAYLOAD_CASE( EcalTimeBiasCorrections )
      FETCH_PAYLOAD_CASE( EcalTimeDependentCorrections )
      FETCH_PAYLOAD_CASE( EcalTPGCrystalStatus )
      FETCH_PAYLOAD_CASE( EcalTPGFineGrainEBGroup )
      FETCH_PAYLOAD_CASE( EcalTPGFineGrainEBIdMap )
      FETCH_PAYLOAD_CASE( EcalTPGFineGrainStripEE )
      FETCH_PAYLOAD_CASE( EcalTPGFineGrainTowerEE )
      FETCH_PAYLOAD_CASE( EcalTPGLinearizationConst )
      FETCH_PAYLOAD_CASE( EcalTPGLutGroup )
      FETCH_PAYLOAD_CASE( EcalTPGLutIdMap )
      FETCH_PAYLOAD_CASE( EcalTPGPedestals )
      FETCH_PAYLOAD_CASE( EcalTPGPhysicsConst )
      FETCH_PAYLOAD_CASE( EcalTPGSlidingWindow )
      FETCH_PAYLOAD_CASE( EcalTPGSpike )
      FETCH_PAYLOAD_CASE( EcalTPGStripStatus )
      FETCH_PAYLOAD_CASE( EcalTPGTowerStatus )
      FETCH_PAYLOAD_CASE( EcalTPGWeightGroup )
      FETCH_PAYLOAD_CASE( EcalTPGWeightIdMap )
      FETCH_PAYLOAD_CASE( EcalTimeOffsetConstant )
      FETCH_PAYLOAD_CASE( EcalWeightXtalGroups )
      FETCH_PAYLOAD_CASE( EcalSamplesCorrelation )
      FETCH_PAYLOAD_CASE( EcalCondObjectContainer<EcalPulseShape> )
      FETCH_PAYLOAD_CASE( EcalPulseShape )
      FETCH_PAYLOAD_CASE( EcalCondObjectContainer<EcalPulseCovariance> )
      FETCH_PAYLOAD_CASE( EcalPulseCovariance )
      FETCH_PAYLOAD_CASE( EcalCondObjectContainer<EcalPulseSymmCovariance> )
      FETCH_PAYLOAD_CASE( EcalPulseSymmCovariance )
      FETCH_PAYLOAD_CASE( FileBlob )
      FETCH_PAYLOAD_CASE( GBRForest )
      FETCH_PAYLOAD_CASE( GBRForestD )
      FETCH_PAYLOAD_CASE( HBHENegativeEFilter )
      FETCH_PAYLOAD_CASE( HFPhase1PMTParams )
      FETCH_PAYLOAD_CASE( HcalChannelQuality )
      FETCH_PAYLOAD_CASE( HcalDcsValues )
      FETCH_PAYLOAD_CASE( HcalElectronicsMap )
      FETCH_PAYLOAD_CASE( HcalFlagHFDigiTimeParams )
      FETCH_PAYLOAD_CASE( HcalFrontEndMap )
      FETCH_PAYLOAD_CASE( HcalGains )
      FETCH_PAYLOAD_CASE( HcalGainWidths )
      FETCH_PAYLOAD_CASE( HcalL1TriggerObjects )
      FETCH_PAYLOAD_CASE( HcalLUTCorrs )
      FETCH_PAYLOAD_CASE( HcalLongRecoParams )
      FETCH_PAYLOAD_CASE( HcalZDCLowGainFractions )
      FETCH_PAYLOAD_CASE( HcalLutMetadata )
      FETCH_PAYLOAD_CASE( HcalMCParams )
      FETCH_PAYLOAD_CASE( HcalPFCorrs )
      FETCH_PAYLOAD_CASE( HcalPedestalWidths )
      FETCH_PAYLOAD_CASE( HcalPedestals )
      FETCH_PAYLOAD_CASE( HcalQIEData )
      FETCH_PAYLOAD_CASE( HcalSiPMCharacteristics )
      FETCH_PAYLOAD_CASE( HcalSiPMParameters )
      FETCH_PAYLOAD_CASE( HcalRecoParams )
      FETCH_PAYLOAD_CASE( HcalRespCorrs )
      FETCH_PAYLOAD_CASE( HcalTimeCorrs )
      FETCH_PAYLOAD_CASE( HcalTPChannelParameters )
      FETCH_PAYLOAD_CASE( HcalTPParameters )
      FETCH_PAYLOAD_CASE( HcalZSThresholds )
      FETCH_PAYLOAD_CASE( HcalInterpolatedPulseColl )
      FETCH_PAYLOAD_CASE( OOTPileupCorrectionBuffer )
      FETCH_PAYLOAD_CASE( StorableDoubleMap<AbsOOTPileupCorrection> )
      FETCH_PAYLOAD_CASE( JetCorrectorParametersCollection )
      FETCH_PAYLOAD_CASE( JME::JetResolutionObject )
      FETCH_PAYLOAD_CASE( METCorrectorParametersCollection )
      FETCH_PAYLOAD_CASE( MEtXYcorrectParametersCollection )
      FETCH_PAYLOAD_CASE( L1CaloEcalScale )
      FETCH_PAYLOAD_CASE( L1CaloEtScale )
      FETCH_PAYLOAD_CASE( L1CaloGeometry )
      FETCH_PAYLOAD_CASE( L1CaloHcalScale )
      FETCH_PAYLOAD_CASE( L1GctChannelMask )
      FETCH_PAYLOAD_CASE( L1GctJetFinderParams )
      FETCH_PAYLOAD_CASE( L1GtBoardMaps )
      FETCH_PAYLOAD_CASE( L1GtParameters )
      FETCH_PAYLOAD_CASE( L1GtPrescaleFactors )
      FETCH_PAYLOAD_CASE( L1GtPsbSetup )
      FETCH_PAYLOAD_CASE( L1GtStableParameters )
      FETCH_PAYLOAD_CASE( L1GtTriggerMask )
      FETCH_PAYLOAD_CASE( L1GtTriggerMenu )
      FETCH_PAYLOAD_CASE( L1MuCSCPtLut )
      FETCH_PAYLOAD_CASE( L1MuCSCTFAlignment )
      FETCH_PAYLOAD_CASE( L1MuCSCTFConfiguration )
      FETCH_PAYLOAD_CASE( L1MuDTEtaPatternLut )
      FETCH_PAYLOAD_CASE( L1MuDTExtLut )
      FETCH_PAYLOAD_CASE( L1MuDTPhiLut )
      FETCH_PAYLOAD_CASE( L1MuDTPtaLut )
      FETCH_PAYLOAD_CASE( L1MuDTQualPatternLut )
      FETCH_PAYLOAD_CASE( L1MuDTTFMasks )
      FETCH_PAYLOAD_CASE( L1MuDTTFParameters )
      FETCH_PAYLOAD_CASE( L1MuGMTChannelMask )
      FETCH_PAYLOAD_CASE( L1MuGMTParameters )
      FETCH_PAYLOAD_CASE( L1MuGMTScales )
      FETCH_PAYLOAD_CASE( L1MuTriggerPtScale )
      FETCH_PAYLOAD_CASE( L1MuTriggerScales )
      FETCH_PAYLOAD_CASE( L1RCTChannelMask )
      FETCH_PAYLOAD_CASE( L1RCTNoisyChannelMask )
      FETCH_PAYLOAD_CASE( L1RCTParameters )
      FETCH_PAYLOAD_CASE( L1RPCBxOrConfig )
      FETCH_PAYLOAD_CASE( L1RPCConeDefinition )
      FETCH_PAYLOAD_CASE( L1RPCConfig )
      FETCH_PAYLOAD_CASE( L1RPCHsbConfig ) 
      FETCH_PAYLOAD_CASE( L1RPCHwConfig )
      FETCH_PAYLOAD_CASE( l1t::CaloParams )
      FETCH_PAYLOAD_CASE( l1t::CaloConfig )
      FETCH_PAYLOAD_CASE( L1TMuonBarrelParams )
      FETCH_PAYLOAD_CASE( L1TMuonGlobalParams )
      FETCH_PAYLOAD_CASE( L1TMuonOverlapParams )
      FETCH_PAYLOAD_CASE( L1TUtmAlgorithm )
      FETCH_PAYLOAD_CASE( L1TUtmBin )
      FETCH_PAYLOAD_CASE( L1TUtmCondition )
      FETCH_PAYLOAD_CASE( L1TUtmCut )
      FETCH_PAYLOAD_CASE( L1TUtmCutValue )
      FETCH_PAYLOAD_CASE( L1TUtmObject )
      FETCH_PAYLOAD_CASE( L1TUtmScale )
      FETCH_PAYLOAD_CASE( L1TUtmTriggerMenu )
      FETCH_PAYLOAD_CASE( L1TGlobalParameters )
      FETCH_PAYLOAD_CASE( L1TriggerKey )
      FETCH_PAYLOAD_CASE( L1TriggerKeyList )
      FETCH_PAYLOAD_CASE( lumi::LumiSectionData )
      FETCH_PAYLOAD_CASE( MixingModuleConfig )
      FETCH_PAYLOAD_CASE( MuScleFitDBobject )
      FETCH_PAYLOAD_CASE( DYTThrObject )
      FETCH_PAYLOAD_CASE( DYTParamObject )
      FETCH_PAYLOAD_CASE( PhysicsTools::Calibration::MVAComputerContainer )
      FETCH_PAYLOAD_CASE( PhysicsTGraphPayload )
      FETCH_PAYLOAD_CASE( PhysicsTFormulaPayload )
      FETCH_PAYLOAD_CASE( PCaloGeometry )
      FETCH_PAYLOAD_CASE( HcalParameters )
      FETCH_PAYLOAD_CASE( PGeometricDet )
      FETCH_PAYLOAD_CASE( PGeometricDetExtra )
      FETCH_PAYLOAD_CASE( PTrackerParameters )
      FETCH_PAYLOAD_CASE( PHGCalParameters )
      //FETCH_PAYLOAD_CASE( PerformancePayload )
      FETCH_PAYLOAD_CASE( PerformancePayloadFromTable )
      FETCH_PAYLOAD_CASE( PerformancePayloadFromTFormula )
      FETCH_PAYLOAD_CASE( PerformancePayloadFromBinnedTFormula )
      FETCH_PAYLOAD_CASE( PerformanceWorkingPoint )
      FETCH_PAYLOAD_CASE( PhysicsTools::Calibration::HistogramD3D )
      FETCH_PAYLOAD_CASE( QGLikelihoodCategory                )
      FETCH_PAYLOAD_CASE( QGLikelihoodObject                  )
      FETCH_PAYLOAD_CASE( QGLikelihoodSystematicsObject     )
      FETCH_PAYLOAD_CASE( RPCEMap )
      FETCH_PAYLOAD_CASE( RPCClusterSize )
      FETCH_PAYLOAD_CASE( RPCStripNoises )
      FETCH_PAYLOAD_CASE( RPCObFebmap )
      FETCH_PAYLOAD_CASE( RPCObGas )
      FETCH_PAYLOAD_CASE( RPCObImon )
      FETCH_PAYLOAD_CASE( RPCObGasMix )
      FETCH_PAYLOAD_CASE( RPCObPVSSmap )
      FETCH_PAYLOAD_CASE( RPCObStatus )
      FETCH_PAYLOAD_CASE( RPCObTemp )
      FETCH_PAYLOAD_CASE( RPCObUXC )
      FETCH_PAYLOAD_CASE( RPCObVmon )
      FETCH_PAYLOAD_CASE( RPCLBLinkMap )
      FETCH_PAYLOAD_CASE( RPCDCCLinkMap )
      FETCH_PAYLOAD_CASE( RPCAMCLinkMap )
      FETCH_PAYLOAD_CASE( RPFlatParams )
      FETCH_PAYLOAD_CASE( RecoIdealGeometry )
      FETCH_PAYLOAD_CASE( RunInfo )
      FETCH_PAYLOAD_CASE( SiPixelCalibConfiguration )
      FETCH_PAYLOAD_CASE( SiPixelCPEGenericErrorParm )
      FETCH_PAYLOAD_CASE( SiPixelFedCablingMap )
      FETCH_PAYLOAD_CASE( SiPixelGainCalibrationForHLT )
      FETCH_PAYLOAD_CASE( SiPixelGainCalibrationOffline )
      FETCH_PAYLOAD_CASE( SiPixelGenErrorDBObject )
      FETCH_PAYLOAD_CASE( SiPixelLorentzAngle )
      FETCH_PAYLOAD_CASE( SiPixelDynamicInefficiency )
      FETCH_PAYLOAD_CASE( SiPixelQuality )
      FETCH_PAYLOAD_CASE( SiPixelTemplateDBObject )
      FETCH_PAYLOAD_CASE( SiPixel2DTemplateDBObject )
      FETCH_PAYLOAD_CASE( SiStripApvGain )
      FETCH_PAYLOAD_CASE( SiStripBackPlaneCorrection )
      FETCH_PAYLOAD_CASE( SiStripBadStrip )
      FETCH_PAYLOAD_CASE( SiStripConfObject )
      FETCH_PAYLOAD_CASE( SiStripDetVOff )
      FETCH_PAYLOAD_CASE( SiStripFedCabling )
      FETCH_PAYLOAD_CASE( SiStripLatency )
      FETCH_PAYLOAD_CASE( SiStripLorentzAngle )
      FETCH_PAYLOAD_CASE( SiStripNoises )
      FETCH_PAYLOAD_CASE( SiStripPedestals )
      FETCH_PAYLOAD_CASE( SiStripThreshold )
      FETCH_PAYLOAD_CASE( TrackProbabilityCalibration )
      FETCH_PAYLOAD_CASE( cond::BaseKeyed )
      FETCH_PAYLOAD_CASE( ESCondObjectContainer<ESChannelStatusCode> )
      FETCH_PAYLOAD_CASE( ESCondObjectContainer<ESPedestal> )
      FETCH_PAYLOAD_CASE( ESCondObjectContainer<float> )
      FETCH_PAYLOAD_CASE( EcalCondObjectContainer<EcalChannelStatusCode> )
      FETCH_PAYLOAD_CASE( EcalCondObjectContainer<EcalMGPAGainRatio> )
      FETCH_PAYLOAD_CASE( EcalCondObjectContainer<EcalTPGPedestal> )
      FETCH_PAYLOAD_CASE( EcalCondObjectContainer<EcalXtalGroupId> )
      FETCH_PAYLOAD_CASE( EcalCondObjectContainer<float> )
      FETCH_PAYLOAD_CASE( MagFieldConfig )
      FETCH_PAYLOAD_CASE( L1TGlobalPrescalesVetos )

      //   
      if( payloadTypeName == "PhysicsTools::Calibration::Histogram3D<double,double,double,double>" ){    
    auto payload = deserialize<PhysicsTools::Calibration::Histogram3D<double,double,double,double> >(payloadTypeName, data, streamerInfo );
    payloadPtr = payload;
    match = true;
      }
      if( payloadTypeName == "PhysicsTools::Calibration::Histogram2D<double,double,double>" ){    
    auto payload = deserialize<PhysicsTools::Calibration::Histogram2D<double,double,double> >(payloadTypeName, data, streamerInfo );
    payloadPtr = payload;
    match = true;
      }
      if( payloadTypeName == "std::vector<unsignedlonglong,std::allocator<unsignedlonglong>>" ){
    auto payload = deserialize<std::vector<unsigned long long> >( payloadTypeName, data, streamerInfo );
    payloadPtr = payload;
    match = true;
      }
  
      if( ! match ) throwException( "Payload type \""+payloadTypeName+"\" is unknown.","fetch" );
      return std::make_pair( payloadTypeName, payloadPtr );
    }

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

Definition at line 8 of file GTProxy.cc.

Referenced by CondDBESSource::CondDBESSource().

                                                                                          {
      if(connectionString.empty()) return tag;
      return  tag+"@["+connectionString+"]";
    }

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 countslash(), getConnectionProtocol(), edm::Service< T >::isAvailable(), checklumidiff::l, edm::SiteLocalConfig::lookupCalibConnect(), parseFipConnectionString(), alignCSCRings::s, AlCaHLTBitMon_QueryRunRegistry::string, and cond::throwException().

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

                                                                                         {
      if( connectionString.empty() ) cond::throwException( "The connection string is empty.", "getConnectionParams" ); 
      std::string protocol = getConnectionProtocol( connectionString );
      std::string finalConn = connectionString;
      std::string refreshConn( "" );
      if( protocol == "frontier" ) {
        std::string protocol( "frontier://" );
        std::string::size_type fpos = connectionString.find( protocol );
        unsigned int nslash = countslash( connectionString.substr( protocol.size(), connectionString.size() - fpos ) );
        if( nslash==1 ) {
          edm::Service<edm::SiteLocalConfig> localconfservice;
          if( !localconfservice.isAvailable() ) {
        cond::throwException( "edm::SiteLocalConfigService is not available", "getConnectionParams" );
          }
          finalConn = localconfservice->lookupCalibConnect( connectionString );
        }
        if( !transactionId.empty() ) {
          size_t l = finalConn.rfind('/');
          finalConn.insert( l, "(freshkey="+transactionId+')' );
          }

        //When the signature parameter is set to sig, FroNTier requests that the server sends digital signatures on every response.
        //We test here that the signature string, if defined, is actually set to sig, otherwise we throw an exception
        std::string signatureParameter( "sig" );
        if( !signature.empty() ) {
          if( signature.compare( signatureParameter ) == 0 ) {
            std::string::size_type s = finalConn.rfind('/');
            finalConn.insert( s, "(security="+signature+')' );
          } else {
        cond::throwException( "The FroNTier security option is invalid.", "getConnectionParams" );
          }
        }

        std::string::size_type startRefresh = finalConn.find( "://" );
          if( startRefresh != std::string::npos ) {
          startRefresh += 3;
        }
        std::string::size_type endRefresh=finalConn.rfind( "/", std::string::npos );
          if( endRefresh == std::string::npos ) {
          refreshConn = finalConn;
        } else {
          refreshConn = finalConn.substr( startRefresh, endRefresh - startRefresh );
          if( refreshConn.substr( 0, 1 ) != "(" ) {
            //if the connect string is not a complicated parenthesized string,
            // an http:// needs to be at the beginning of it
            refreshConn.insert( 0, "http://" );
          }
        }
      } else if( protocol == "sqlite_fip" ) {
        finalConn = parseFipConnectionString( connectionString ); 
      }
      return std::make_pair( finalConn, refreshConn ); 
    }

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

inline

Definition at line 85 of file Utils.h.

References AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

Referenced by getConnectionParams(), and parseConnectionString().

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

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

Definition at line 36 of file CondDBImport.cc.

References cmsStageWithFailover::destination, IMPORT_PAYLOAD_CASE, match(), MuonAssociatorByHits_cfi::obj, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

                                                                                                                                                   {
      cond::Hash payloadId("");
      bool newInsert = false;
      bool match = false;
      if( inputPtr ){
      IMPORT_PAYLOAD_CASE( std::string ) 
      IMPORT_PAYLOAD_CASE( std::vector<unsigned long long> )
      IMPORT_PAYLOAD_CASE( AlCaRecoTriggerBits )
      IMPORT_PAYLOAD_CASE( AlignmentErrors )
      IMPORT_PAYLOAD_CASE( AlignmentErrorsExtended )
      IMPORT_PAYLOAD_CASE( AlignmentSurfaceDeformations )
      IMPORT_PAYLOAD_CASE( Alignments )
      IMPORT_PAYLOAD_CASE( AlignPCLThresholds )
      IMPORT_PAYLOAD_CASE( BeamSpotObjects )
      IMPORT_PAYLOAD_CASE( CSCBadChambers )
      IMPORT_PAYLOAD_CASE( CSCBadStrips )
      IMPORT_PAYLOAD_CASE( CSCBadWires )
      IMPORT_PAYLOAD_CASE( CSCChamberIndex )
      IMPORT_PAYLOAD_CASE( CSCChamberMap )
      IMPORT_PAYLOAD_CASE( CSCChamberTimeCorrections )
      IMPORT_PAYLOAD_CASE( CSCCrateMap )
      IMPORT_PAYLOAD_CASE( CSCDBChipSpeedCorrection )
      IMPORT_PAYLOAD_CASE( CSCDBCrosstalk )
      IMPORT_PAYLOAD_CASE( CSCDBGains )
      IMPORT_PAYLOAD_CASE( CSCDBGasGainCorrection )
      IMPORT_PAYLOAD_CASE( CSCDBL1TPParameters )
      IMPORT_PAYLOAD_CASE( CSCDBNoiseMatrix )
      IMPORT_PAYLOAD_CASE( CSCDBPedestals )
      IMPORT_PAYLOAD_CASE( CSCDDUMap )
      IMPORT_PAYLOAD_CASE( CSCL1TPParameters )
      IMPORT_PAYLOAD_CASE( CSCRecoDigiParameters )
      IMPORT_PAYLOAD_CASE( CTPPSPixelDAQMapping )
      IMPORT_PAYLOAD_CASE( CTPPSPixelAnalysisMask )
      IMPORT_PAYLOAD_CASE( CastorChannelQuality )
      IMPORT_PAYLOAD_CASE( CastorElectronicsMap )
      IMPORT_PAYLOAD_CASE( CastorGainWidths )
      IMPORT_PAYLOAD_CASE( CastorGains )
      IMPORT_PAYLOAD_CASE( CastorPedestalWidths )
      IMPORT_PAYLOAD_CASE( CastorPedestals )
      IMPORT_PAYLOAD_CASE( CastorQIEData )
      IMPORT_PAYLOAD_CASE( CastorRecoParams )
      IMPORT_PAYLOAD_CASE( CastorSaturationCorrs )
      IMPORT_PAYLOAD_CASE( CentralityTable )
      IMPORT_PAYLOAD_CASE( DTCCBConfig )
      IMPORT_PAYLOAD_CASE( DTDeadFlag )
      IMPORT_PAYLOAD_CASE( DTHVStatus )
      IMPORT_PAYLOAD_CASE( DTKeyedConfig )
      IMPORT_PAYLOAD_CASE( DTLVStatus )
      IMPORT_PAYLOAD_CASE( DTMtime )
      IMPORT_PAYLOAD_CASE( DTReadOutMapping )
      IMPORT_PAYLOAD_CASE( DTRecoConditions )
      IMPORT_PAYLOAD_CASE( DTRecoUncertainties )
      IMPORT_PAYLOAD_CASE( DTStatusFlag )
      IMPORT_PAYLOAD_CASE( DTT0 )
      IMPORT_PAYLOAD_CASE( DTTPGParameters )
      IMPORT_PAYLOAD_CASE( DTTtrig )
      IMPORT_PAYLOAD_CASE( DropBoxMetadata )
      IMPORT_PAYLOAD_CASE( ESChannelStatus )
      IMPORT_PAYLOAD_CASE( ESEEIntercalibConstants )
      IMPORT_PAYLOAD_CASE( ESFloatCondObjectContainer )
      IMPORT_PAYLOAD_CASE( ESGain )
      IMPORT_PAYLOAD_CASE( ESMIPToGeVConstant )
      IMPORT_PAYLOAD_CASE( ESMissingEnergyCalibration )
      IMPORT_PAYLOAD_CASE( ESPedestals )
      IMPORT_PAYLOAD_CASE( ESRecHitRatioCuts )
      IMPORT_PAYLOAD_CASE( ESThresholds )
      IMPORT_PAYLOAD_CASE( ESTimeSampleWeights )
      IMPORT_PAYLOAD_CASE( EcalADCToGeVConstant )
      IMPORT_PAYLOAD_CASE( EcalChannelStatus )
      IMPORT_PAYLOAD_CASE( EcalClusterEnergyCorrectionObjectSpecificParameters )
      IMPORT_PAYLOAD_CASE( EcalDAQTowerStatus )
      IMPORT_PAYLOAD_CASE( EcalDCSTowerStatus )
      IMPORT_PAYLOAD_CASE( EcalDQMChannelStatus )
      IMPORT_PAYLOAD_CASE( EcalDQMTowerStatus )
      IMPORT_PAYLOAD_CASE( EcalFloatCondObjectContainer )
      IMPORT_PAYLOAD_CASE( EcalFunParams )
      IMPORT_PAYLOAD_CASE( EcalGainRatios )
      IMPORT_PAYLOAD_CASE( EcalLaserAPDPNRatios )
      IMPORT_PAYLOAD_CASE( EcalMappingElectronics )
      IMPORT_PAYLOAD_CASE( EcalCondObjectContainer<EcalMappingElement> )
      IMPORT_PAYLOAD_CASE( EcalCondObjectContainer<EcalPedestal> )
      IMPORT_PAYLOAD_CASE( EcalCondObjectContainer<EcalTPGLinearizationConstant> )
      IMPORT_PAYLOAD_CASE( EcalCondObjectContainer<EcalDQMStatusCode> )
      IMPORT_PAYLOAD_CASE( EcalCondObjectContainer<EcalTPGCrystalStatusCode> )
      IMPORT_PAYLOAD_CASE( EcalCondTowerObjectContainer<EcalDAQStatusCode> )
      IMPORT_PAYLOAD_CASE( EcalCondTowerObjectContainer<EcalChannelStatusCode> )
      IMPORT_PAYLOAD_CASE( EcalCondTowerObjectContainer<EcalDQMStatusCode> )
      IMPORT_PAYLOAD_CASE( EcalPedestals )
      IMPORT_PAYLOAD_CASE( EcalSRSettings )
      IMPORT_PAYLOAD_CASE( EcalSampleMask )
      IMPORT_PAYLOAD_CASE( EcalTBWeights )
      IMPORT_PAYLOAD_CASE( EcalTPGCrystalStatus )
      IMPORT_PAYLOAD_CASE( EcalTPGFineGrainEBGroup )
      IMPORT_PAYLOAD_CASE( EcalTPGFineGrainEBIdMap )
      IMPORT_PAYLOAD_CASE( EcalTPGFineGrainStripEE )
      IMPORT_PAYLOAD_CASE( EcalTPGFineGrainTowerEE )
      IMPORT_PAYLOAD_CASE( EcalTPGLinearizationConst )
      IMPORT_PAYLOAD_CASE( EcalTPGLutGroup )
      IMPORT_PAYLOAD_CASE( EcalTPGLutIdMap )
      IMPORT_PAYLOAD_CASE( EcalTPGPedestals )
      IMPORT_PAYLOAD_CASE( EcalTPGPhysicsConst )
      IMPORT_PAYLOAD_CASE( EcalTPGSlidingWindow )
      IMPORT_PAYLOAD_CASE( EcalTPGSpike )
      IMPORT_PAYLOAD_CASE( EcalTPGStripStatus )
      IMPORT_PAYLOAD_CASE( EcalTPGTowerStatus )
      IMPORT_PAYLOAD_CASE( EcalTPGWeightGroup )
      IMPORT_PAYLOAD_CASE( EcalTPGWeightIdMap )
      IMPORT_PAYLOAD_CASE( EcalTimeBiasCorrections )
      IMPORT_PAYLOAD_CASE( EcalTimeOffsetConstant )
      IMPORT_PAYLOAD_CASE( EcalTimeDependentCorrections )
      IMPORT_PAYLOAD_CASE( EcalWeightXtalGroups )
      IMPORT_PAYLOAD_CASE( EcalSamplesCorrelation )
      IMPORT_PAYLOAD_CASE( EcalCondObjectContainer<EcalPulseShape> )
      IMPORT_PAYLOAD_CASE( EcalPulseShape )
      IMPORT_PAYLOAD_CASE( EcalCondObjectContainer<EcalPulseCovariance> )
      IMPORT_PAYLOAD_CASE( EcalPulseCovariance )
      IMPORT_PAYLOAD_CASE( EcalCondObjectContainer<EcalPulseSymmCovariance> )
      IMPORT_PAYLOAD_CASE( EcalPulseSymmCovariance )
      IMPORT_PAYLOAD_CASE( FileBlob )
      IMPORT_PAYLOAD_CASE( GBRForest )
      IMPORT_PAYLOAD_CASE( GBRForestD )
      IMPORT_PAYLOAD_CASE( HBHENegativeEFilter )
      IMPORT_PAYLOAD_CASE( HFPhase1PMTParams )
      IMPORT_PAYLOAD_CASE( HcalChannelQuality )
      IMPORT_PAYLOAD_CASE( HcalDcsValues )
      IMPORT_PAYLOAD_CASE( HcalElectronicsMap )
      IMPORT_PAYLOAD_CASE( HcalFlagHFDigiTimeParams )
      IMPORT_PAYLOAD_CASE( HcalFrontEndMap )
      IMPORT_PAYLOAD_CASE( HcalGains )
      IMPORT_PAYLOAD_CASE( HcalGainWidths )
      IMPORT_PAYLOAD_CASE( HcalL1TriggerObjects )
      IMPORT_PAYLOAD_CASE( HcalLUTCorrs )
      IMPORT_PAYLOAD_CASE( HcalLongRecoParams )
      IMPORT_PAYLOAD_CASE( HcalZDCLowGainFractions )
      IMPORT_PAYLOAD_CASE( HcalLutMetadata )
      IMPORT_PAYLOAD_CASE( HcalMCParams )
      IMPORT_PAYLOAD_CASE( HcalPFCorrs )
      IMPORT_PAYLOAD_CASE( HcalPedestalWidths )
      IMPORT_PAYLOAD_CASE( HcalPedestals )
      IMPORT_PAYLOAD_CASE( HcalQIEData )
      IMPORT_PAYLOAD_CASE( HcalRecoParams )
      IMPORT_PAYLOAD_CASE( HcalRespCorrs )
      IMPORT_PAYLOAD_CASE( HcalSiPMCharacteristics )
      IMPORT_PAYLOAD_CASE( HcalSiPMParameters )
      IMPORT_PAYLOAD_CASE( HcalTimeCorrs )
      IMPORT_PAYLOAD_CASE( HcalTPChannelParameters )
      IMPORT_PAYLOAD_CASE( HcalTPParameters )
      IMPORT_PAYLOAD_CASE( HcalZSThresholds )
      IMPORT_PAYLOAD_CASE( HcalInterpolatedPulseColl )
      IMPORT_PAYLOAD_CASE( JetCorrectorParametersCollection )
      IMPORT_PAYLOAD_CASE( JME::JetResolutionObject )
      IMPORT_PAYLOAD_CASE( METCorrectorParametersCollection )
      IMPORT_PAYLOAD_CASE( MEtXYcorrectParametersCollection )
      IMPORT_PAYLOAD_CASE( L1CaloEcalScale )
      IMPORT_PAYLOAD_CASE( L1CaloEtScale )
      IMPORT_PAYLOAD_CASE( L1CaloGeometry )
      IMPORT_PAYLOAD_CASE( L1CaloHcalScale )
      IMPORT_PAYLOAD_CASE( L1GctChannelMask )
      IMPORT_PAYLOAD_CASE( L1GctJetFinderParams )
      IMPORT_PAYLOAD_CASE( L1GtBoardMaps )
      IMPORT_PAYLOAD_CASE( L1GtParameters )
      IMPORT_PAYLOAD_CASE( L1GtPrescaleFactors )
      IMPORT_PAYLOAD_CASE( L1GtPsbSetup )
      IMPORT_PAYLOAD_CASE( L1GtStableParameters )
      IMPORT_PAYLOAD_CASE( L1GtTriggerMask )
      IMPORT_PAYLOAD_CASE( L1GtTriggerMenu )
      IMPORT_PAYLOAD_CASE( L1MuCSCPtLut )
      IMPORT_PAYLOAD_CASE( L1MuCSCTFAlignment )
      IMPORT_PAYLOAD_CASE( L1MuCSCTFConfiguration )
      IMPORT_PAYLOAD_CASE( L1MuDTEtaPatternLut )
      IMPORT_PAYLOAD_CASE( L1MuDTExtLut )
      IMPORT_PAYLOAD_CASE( L1MuDTPhiLut )
      IMPORT_PAYLOAD_CASE( L1MuDTPtaLut )
      IMPORT_PAYLOAD_CASE( L1MuDTQualPatternLut )
      IMPORT_PAYLOAD_CASE( L1MuDTTFMasks )
      IMPORT_PAYLOAD_CASE( L1MuDTTFParameters )
      IMPORT_PAYLOAD_CASE( L1MuGMTChannelMask )
      IMPORT_PAYLOAD_CASE( L1MuGMTParameters )
      IMPORT_PAYLOAD_CASE( L1MuGMTScales )
      IMPORT_PAYLOAD_CASE( L1MuTriggerPtScale )
      IMPORT_PAYLOAD_CASE( L1MuTriggerScales )
      IMPORT_PAYLOAD_CASE( L1RCTChannelMask )
      IMPORT_PAYLOAD_CASE( L1RCTNoisyChannelMask )
      IMPORT_PAYLOAD_CASE( L1RCTParameters )
      IMPORT_PAYLOAD_CASE( L1RPCBxOrConfig )
      IMPORT_PAYLOAD_CASE( L1RPCConeDefinition )
      IMPORT_PAYLOAD_CASE( L1RPCConfig )
      IMPORT_PAYLOAD_CASE( L1RPCHsbConfig ) 
      IMPORT_PAYLOAD_CASE( L1RPCHwConfig )
      IMPORT_PAYLOAD_CASE( l1t::CaloParams )
      IMPORT_PAYLOAD_CASE( l1t::CaloConfig )
      IMPORT_PAYLOAD_CASE( L1TMuonBarrelParams )
      IMPORT_PAYLOAD_CASE( L1TMuonGlobalParams )
      IMPORT_PAYLOAD_CASE( L1TMuonOverlapParams )
      IMPORT_PAYLOAD_CASE( L1TUtmAlgorithm )
      IMPORT_PAYLOAD_CASE( L1TUtmBin )
      IMPORT_PAYLOAD_CASE( L1TUtmCondition )
      IMPORT_PAYLOAD_CASE( L1TUtmCut )
      IMPORT_PAYLOAD_CASE( L1TUtmCutValue )
      IMPORT_PAYLOAD_CASE( L1TUtmObject )
      IMPORT_PAYLOAD_CASE( L1TUtmScale )
      IMPORT_PAYLOAD_CASE( L1TUtmTriggerMenu )
      IMPORT_PAYLOAD_CASE( L1TGlobalParameters )
      IMPORT_PAYLOAD_CASE( L1TriggerKey )
      IMPORT_PAYLOAD_CASE( MagFieldConfig )
      if( inputTypeName == "L1TriggerKeyList" ){ 
    match = true;
    throwException( "Import of \"L1TriggerKeyList\" type payloads is not supported.","import" );
      }
      //IMPORT_PAYLOAD_CASE( L1TriggerKeyList )
      IMPORT_PAYLOAD_CASE( lumi::LumiSectionData )
      IMPORT_PAYLOAD_CASE( MixingModuleConfig )
      IMPORT_PAYLOAD_CASE( MuScleFitDBobject )
      IMPORT_PAYLOAD_CASE( DYTThrObject )
      IMPORT_PAYLOAD_CASE( DYTParamObject )
      IMPORT_PAYLOAD_CASE( OOTPileupCorrectionBuffer )
      IMPORT_PAYLOAD_CASE( StorableDoubleMap<AbsOOTPileupCorrection> )
      IMPORT_PAYLOAD_CASE( PhysicsTools::Calibration::MVAComputerContainer )
      IMPORT_PAYLOAD_CASE( PCaloGeometry )
      IMPORT_PAYLOAD_CASE( HcalParameters )
      IMPORT_PAYLOAD_CASE( PGeometricDet )
      IMPORT_PAYLOAD_CASE( PGeometricDetExtra )
      IMPORT_PAYLOAD_CASE( PTrackerParameters )
      IMPORT_PAYLOAD_CASE( PHGCalParameters )
    //IMPORT_PAYLOAD_CASE( PerformancePayload )
      IMPORT_PAYLOAD_CASE( PerformancePayloadFromTable )
      IMPORT_PAYLOAD_CASE( PerformancePayloadFromTFormula )
      IMPORT_PAYLOAD_CASE( PerformancePayloadFromBinnedTFormula )
      IMPORT_PAYLOAD_CASE( PerformanceWorkingPoint )
      IMPORT_PAYLOAD_CASE( PhysicsTGraphPayload )
      IMPORT_PAYLOAD_CASE( PhysicsTFormulaPayload )
      IMPORT_PAYLOAD_CASE( PhysicsTools::Calibration::HistogramD3D )
      IMPORT_PAYLOAD_CASE( QGLikelihoodCategory                     )
      IMPORT_PAYLOAD_CASE( QGLikelihoodObject               )
      IMPORT_PAYLOAD_CASE( QGLikelihoodSystematicsObject     )
      IMPORT_PAYLOAD_CASE( RPCEMap )
      IMPORT_PAYLOAD_CASE( RPCClusterSize )
      IMPORT_PAYLOAD_CASE( RPCStripNoises )
      IMPORT_PAYLOAD_CASE( RPCObFebmap )
      IMPORT_PAYLOAD_CASE( RPCObGas )
      IMPORT_PAYLOAD_CASE( RPCObImon )
      IMPORT_PAYLOAD_CASE( RPCObGasMix )
      IMPORT_PAYLOAD_CASE( RPCObPVSSmap )
      IMPORT_PAYLOAD_CASE( RPCObStatus )
      IMPORT_PAYLOAD_CASE( RPCObTemp )
      IMPORT_PAYLOAD_CASE( RPCObUXC )
      IMPORT_PAYLOAD_CASE( RPCObVmon )
      IMPORT_PAYLOAD_CASE( RPCLBLinkMap )
      IMPORT_PAYLOAD_CASE( RPCDCCLinkMap )
      IMPORT_PAYLOAD_CASE( RPCAMCLinkMap )
      IMPORT_PAYLOAD_CASE( RPFlatParams )
      IMPORT_PAYLOAD_CASE( RecoIdealGeometry )
      IMPORT_PAYLOAD_CASE( RunInfo )
      IMPORT_PAYLOAD_CASE( SiPixelCalibConfiguration )
      IMPORT_PAYLOAD_CASE( SiPixelCPEGenericErrorParm )
      IMPORT_PAYLOAD_CASE( SiPixelFedCablingMap )
      IMPORT_PAYLOAD_CASE( SiPixelGainCalibrationForHLT )
      IMPORT_PAYLOAD_CASE( SiPixelGainCalibrationOffline )
      IMPORT_PAYLOAD_CASE( SiPixelGenErrorDBObject )
      IMPORT_PAYLOAD_CASE( SiPixelLorentzAngle )
      IMPORT_PAYLOAD_CASE( SiPixelDynamicInefficiency )
      IMPORT_PAYLOAD_CASE( SiPixelQuality )
      IMPORT_PAYLOAD_CASE( SiPixelTemplateDBObject )
      IMPORT_PAYLOAD_CASE( SiPixel2DTemplateDBObject )
      IMPORT_PAYLOAD_CASE( SiStripApvGain )
      IMPORT_PAYLOAD_CASE( SiStripBadStrip )
      IMPORT_PAYLOAD_CASE( SiStripBackPlaneCorrection )
      IMPORT_PAYLOAD_CASE( SiStripConfObject )
      IMPORT_PAYLOAD_CASE( SiStripDetVOff )
      IMPORT_PAYLOAD_CASE( SiStripFedCabling )
      IMPORT_PAYLOAD_CASE( SiStripLatency )
      IMPORT_PAYLOAD_CASE( SiStripLorentzAngle )
      IMPORT_PAYLOAD_CASE( SiStripNoises )
      IMPORT_PAYLOAD_CASE( SiStripPedestals )
      IMPORT_PAYLOAD_CASE( SiStripThreshold )
      IMPORT_PAYLOAD_CASE( TrackProbabilityCalibration )
      IMPORT_PAYLOAD_CASE( cond::BaseKeyed )
      IMPORT_PAYLOAD_CASE( ESCondObjectContainer<ESChannelStatusCode> )
      IMPORT_PAYLOAD_CASE( ESCondObjectContainer<ESPedestal> )
      IMPORT_PAYLOAD_CASE( ESCondObjectContainer<float> )
      IMPORT_PAYLOAD_CASE( EcalCondObjectContainer<EcalChannelStatusCode> )
      IMPORT_PAYLOAD_CASE( EcalCondObjectContainer<EcalMGPAGainRatio> )
      IMPORT_PAYLOAD_CASE( EcalCondObjectContainer<EcalTPGPedestal> )
      IMPORT_PAYLOAD_CASE( EcalCondObjectContainer<EcalXtalGroupId> )
      IMPORT_PAYLOAD_CASE( EcalCondObjectContainer<float> )
      IMPORT_PAYLOAD_CASE( L1TGlobalPrescalesVetos )
      if( inputTypeName == "PhysicsTools::Calibration::Histogram3D<double,double,double,double>" ){
    match = true;
    const PhysicsTools::Calibration::Histogram3D<double,double,double,double>& obj = *static_cast<const PhysicsTools::Calibration::Histogram3D<double,double,double,double>*>( inputPtr ); 
    payloadId = destination.storePayload( obj, boost::posix_time::microsec_clock::universal_time() ); 
      } 
      if( inputTypeName == "PhysicsTools::Calibration::Histogram2D<double,double,double>" ){
    match = true;
    const PhysicsTools::Calibration::Histogram2D<double,double,double>& obj = *static_cast<const PhysicsTools::Calibration::Histogram2D<double,double,double>*>( inputPtr ); 
    payloadId = destination.storePayload( obj, boost::posix_time::microsec_clock::universal_time() ); 
      } 
      if( inputTypeName == "std::vector<unsignedlonglong,std::allocator<unsignedlonglong>>" ){
    match = true;
    const std::vector<unsigned long long>& obj = *static_cast<const std::vector<unsigned long long>*>( inputPtr );
    payloadId = destination.storePayload( obj, boost::posix_time::microsec_clock::universal_time() );
      }
      
      if( ! match ) throwException( "Payload type \""+inputTypeName+"\" is unknown.","import" );
      }
      return payloadId;
    }

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

References begin, cond::persistency::IOVProxy::begin(), cond::persistency::Session::connectionString(), gather_cfg::cout, cond::persistency::Session::createDatabase(), cond::persistency::Session::createIov(), reco::dp, cond::persistency::Session::editIov(), idDealer::editor, end, cond::persistency::IOVProxy::end(), cond::persistency::Session::existsDatabase(), cond::persistency::Session::existsIov(), cond::persistency::IOVProxy::find(), cond::persistency::IOVEditor::flush(), cond::persistency::IOVProxy::getInterval(), importPayload(), cond::persistency::IOVEditor::insert(), cond::persistency::Session::iovProxy(), cond::persistency::IOVProxy::loadedSize(), cond::persistency::IOVProxy::loadRange(), AlCaHLTBitMon_ParallelJobs::p, cond::persistency::IOVProxy::payloadObjectType(), cond::persistency::IOVEditor::payloadType(), cond::persistency::Session::readIov(), cond::persistency::IOVEditor::setDescription(), ntuplemaker::since, createPayload::skip, cond::persistency::TransactionScope::start(), cond::persistency::IOVProxy::synchronizationType(), throwException(), cond::persistency::IOVEditor::timeType(), cond::persistency::IOVProxy::timeType(), and cond::persistency::Session::transaction().

                                 {
      persistency::TransactionScope ssc( sourceSession.transaction() );
      ssc.start();
      std::cout <<"    Loading source iov..."<<std::endl;
      persistency::IOVProxy p = sourceSession.readIov( sourceTag, true );
      if( p.loadedSize()==0 ) {
    std::cout <<"    Tag contains 0 iovs."<<std::endl; 
    return 0;
      } else {
    std::cout <<"    Iov size:"<<p.loadedSize()<<" timeType:"<<p.timeType()<<" payloadObjectType=\""<<p.payloadObjectType()<<"\""<<std::endl;
      }
      if( (*p.begin()).since > begin ) begin = (*p.begin()).since;
      if( end < begin ) {
    std::cout <<"    No Iov in the selected range."<<std::endl; 
    return 0;
      }
      persistency::IOVEditor editor;
      persistency::TransactionScope dsc( destSession.transaction() );
      dsc.start( false );
      bool exists = false;
      if( !destSession.existsDatabase() ) {
    destSession.createDatabase();
      } else {
    exists = destSession.existsIov( destTag );
      }
      persistency::IOVProxy dp;
      if( exists ){
    dp = destSession.readIov( destTag );
    editor = destSession.editIov( destTag );
    if( !description.empty() ) std::cout <<"   INFO. Destination Tag "<<destTag<<" already exists. Provided description will be ignored."<<std::endl;
    if( editor.timeType() != p.timeType() )
      throwException( "TimeType of the destination tag does not match with the source tag timeType.", "importIovs"); 
    if( editor.payloadType() != p.payloadObjectType() )
      throwException( "PayloadType of the destination tag does not match with the source tag payloadType.", "importIovs");
      } else {
    editor = destSession.createIov( p.payloadObjectType(), destTag, p.timeType(), p.synchronizationType() );
    if( description.empty() ) editor.setDescription( "Created copying tag "+sourceTag+" from "+sourceSession.connectionString() );
    else editor.setDescription( description );
      }
      size_t niovs = 0;
      std::set<cond::Hash> pids;
      std::set<cond::Time_t> sinces;
      auto iiov = p.find( begin );
      cond::Time_t newSince = begin;
      while( iiov != p.end() ){ 
    // skip duplicated sinces
    if( sinces.find( newSince ) != sinces.end() ){
      std::cout <<"    WARNING. Skipping duplicated since="<<newSince<<std::endl;
      continue;
    }
    // make sure that we import the payload _IN_USE_
    auto usedIov = p.getInterval( newSince );
    cond::Hash ph = importPayload( sourceSession, usedIov.payloadId, destSession, reserialize );
    pids.insert( ph );
        bool skip = false;
    if( exists ){
      // don't insert if the same entry is already there...
      auto ie = dp.find( newSince );
      if( ie != dp.end() ){
        if( ((*ie).since == newSince) && ((*ie).payloadId == usedIov.payloadId) ) {
          skip = true;
        }
      }
    }
    if( !skip ){
      editor.insert( newSince, ph );
      sinces.insert( newSince );
      niovs++;
      if( niovs && (niovs%1000==0) ) std::cout <<"    Total of iov inserted: "<<niovs<<" payloads: "<<pids.size()<<std::endl;
    }
    iiov++;
    if( iiov == p.end() || (*iiov).since > end ){
      break;
    } else {
      newSince = (*iiov).since;
    }
      } 
      if( exists && override ){
    std::cout <<"    Adding overlying iovs..."<<std::endl;
    persistency::IOVProxy dp;
    dp = destSession.iovProxy();
    dp.loadRange( destTag, begin, end );
    std::set<cond::Time_t> extraSinces;
        for( auto iov : dp ){
          auto siov = p.getInterval( iov.since );
      if( siov.since != iov.since ) {
            if( extraSinces.find( iov.since )==extraSinces.end() ){
          editor.insert( iov.since, siov.payloadId );
          extraSinces.insert( iov.since );
          niovs++;
          if( niovs && (niovs%1000==0) ) std::cout <<"    Total of iov inserted: "<<niovs<<" payloads: "<<pids.size()<<std::endl;
        }
      }
    }           
      }
      std::cout <<"    Total of iov inserted: "<<niovs<<" payloads: "<<pids.size()<<std::endl;
      std::cout <<"    Flushing changes..."<<std::endl;
      editor.flush( editingNote, forceInsert );
      dsc.commit();
      ssc.commit();
      return niovs;
    }

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

Definition at line 16 of file CondDBTools.cc.

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

Referenced by importIovs().

                                                                                                                             {
      if( reserialize ){
    std::pair<std::string,std::shared_ptr<void> > readBackPayload = fetch( sourcePayloadId, sourceSession );
    return import( sourceSession, sourcePayloadId, readBackPayload.first, readBackPayload.second.get(), destSession );
      } else {
    std::string payloadType("");
    cond::Binary payloadData;
    cond::Binary streamerInfoData;
    if( !sourceSession.fetchPayloadData( sourcePayloadId, payloadType, payloadData, streamerInfoData ) ){
      cond::throwException( "Payload with hash"+sourcePayloadId+" has not been found in the source database.","importPayload");
    }
    boost::posix_time::ptime now = boost::posix_time::microsec_clock::universal_time();
    return destSession.storePayloadData( payloadType, std::make_pair( payloadData, streamerInfoData ),now );  
      }
    }  

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 164 of file IOVEditor.cc.

References f.

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

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

template<typename T , typename Arg1 >

bool cond::persistency::is_same_any

(

)

Definition at line 209 of file DbCore.h.

References relativeConstraints::value.

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

template<typename T , typename Arg1 , typename Arg2 , typename... Args>

bool cond::persistency::is_same_any

(

)

Definition at line 213 of file DbCore.h.

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

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

Definition at line 10 of file IOVSchema.cc.

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

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

                                                                            {
      SHA_CTX ctx;
      if( !SHA1_Init( &ctx ) ){
    throwException( "SHA1 initialization error.","IOVSchema::makeHash");
      }
      if( !SHA1_Update( &ctx, objectType.c_str(), objectType.size() ) ){
    throwException( "SHA1 processing error (1).","IOVSchema::makeHash");
      }
      if( !SHA1_Update( &ctx, data.data(), data.size() ) ){
    throwException( "SHA1 processing error (2).","IOVSchema::makeHash");
      }
      unsigned char hash[SHA_DIGEST_LENGTH];
      if( !SHA1_Final(hash, &ctx) ){
    throwException( "SHA1 finalization error.","IOVSchema::makeHash");
      }
      
      char tmp[SHA_DIGEST_LENGTH*2+1];
      // re-write bytes in hex
      for (unsigned int i = 0; i < 20; i++) {                                                                                                        
    ::sprintf(&tmp[i * 2], "%02x", hash[i]);                                                                                                 
      }                                                                                                                                              
      tmp[20*2] = 0;                                                                                                                                 
      return tmp;                                                                                                                                    
    }

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

inline

Definition at line 93 of file Utils.h.

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

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

                                                                                                             {
      std::string protocol = getConnectionProtocol( connectionString );
      std::string serviceName("");
      std::string databaseName("");
      if( protocol == "sqlite" || protocol == "sqlite_file" || protocol == "sqlite_fip" ){
    databaseName = connectionString.substr( protocol.size()+1 ); 
      } else if ( protocol == "oracle" || protocol == "frontier" ){
    size_t ptr = protocol.size()+1;
    if( connectionString.substr( ptr,2 )!="//" ) throwException( "Connection string "+connectionString+
                                     " is invalid format for technology \""+
                                     protocol+"\".","parseConnectionString" );
    ptr += 2;
    size_t serviceEnd = connectionString.find( '/', ptr );
    if( serviceEnd == std::string::npos ) throwException( "Connection string "+connectionString+" is invalid.",
                                  "parseConnectionString" );
    serviceName = connectionString.substr( ptr, serviceEnd-ptr );
    ptr = serviceEnd+1;
    databaseName = connectionString.substr( ptr );
      } else throwException( "Technology "+protocol+" is not known.","parseConnectionString" );
    
      return std::make_tuple( protocol, serviceName, databaseName );
    }

std::string cond::persistency::parseFipConnectionString

(

const std::string &

fipConnect

)

Definition at line 27 of file DbConnectionString.cc.

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

Referenced by getConnectionParams().

                                                                     {
      std::string connect( "sqlite_file:" );
      std::string::size_type pos = fipConnect.find( ':' );
      std::string fipLocation = fipConnect.substr( pos+1 );
      edm::FileInPath fip( fipLocation );
      connect.append( fip.fullPath() );
      return connect;
    }

std::pair< std::string, std::string > cond::persistency::parseTag

(

const std::string &

tag

)

Definition at line 13 of file GTProxy.cc.

References AlCaHLTBitMon_QueryRunRegistry::string, and lumiQTWidget::t.

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

                                                                 {
      std::string pfn("");
      std::string t(tag);
      size_t pos = tag.rfind("[");
      if( pos != std::string::npos && tag.size() >= pos+2 ){
    if( tag[pos-1]=='@' && tag[tag.size()-1]==']' ) {
      pfn = tag.substr( pos+1,tag.size()-pos-2 ); 
      t = tag.substr( 0, pos-1 );
    }
      }
      return std::make_pair( t, pfn );
    }

template<typename T >

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

Definition at line 314 of file IOVProxy.cc.

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

Referenced by dqm_interfaces.DirID::__eq__(), ValidationMatrix::add_to_blacklist(), ValidationMatrix::do_comparisons_threaded(), DQMPFCandidateAnalyzer::dqmBeginRun(), METAnalyzer::dqmBeginRun(), AlignmentMonitorTemplate::event(), HcalIndexLookup::find(), cond::persistency::IOVProxy::find(), FileNamesHelper::getJobID_fromFileName(), ValidationMatrix::guess_blacklists(), ValidationMatrix::guess_params(), parse_int(), and duplicateReflexLibrarySearch::searchClassDefXml().

                                                                                                                            {
      if( !container.size() ) return container.end();
      auto p = std::upper_bound( container.begin(), container.end(), val, IOVComp() );
      return (p!= container.begin()) ? p-1 : container.end();
    }

template<>

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

inline

Definition at line 202 of file Session.h.

References MillePedeFileConverter_cfg::e, cond::serialize(), AlCaHLTBitMon_QueryRunRegistry::string, throwException(), and cms::Exception::what().

                                                                                                                                    {

      std::string payloadObjectType("std::string");
      cond::Hash ret;
      try{
        ret = storePayloadData( payloadObjectType, serialize( payload ), creationTime );
      } catch ( const cond::persistency::Exception& e ){
    std::string em(e.what());
        throwException( "Payload of type "+payloadObjectType+" could not be stored. "+em,"Session::storePayload");
      }
      return ret;
    }

template<typename T , typename P >

void cond::persistency::static_assert_is_same_decayed ( )

inline

Definition at line 81 of file DbCore.h.

References data, cond::Binary::get(), hcalTTPDigis_cfi::id, StGenEvtProducer_cfi::init, dataset::name, AlCaHLTBitMon_QueryRunRegistry::string, cond::synchronizationTypeNames(), cond::time::timeTypeName(), and relativeConstraints::value.

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

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

Definition at line 14 of file Exception.cc.

References cond::persistency::Exception::Exception().

Referenced by cond::CredentialStore::addUser(), L1CondDBPayloadWriterExt::analyze(), L1CondDBIOVWriterExt::analyze(), L1CondDBIOVWriter::analyze(), L1CondDBPayloadWriter::analyze(), cond::service::PoolDBOutputService::appendSinceTime(), MillePedeAlignmentAlgorithm::beginRun(), cond::persistency::RunInfoEditor::checkTransaction(), cond::persistency::GTEditor::checkTransaction(), cond::persistency::IOVEditor::checkTransaction(), cond::persistency::RunInfoProxy::checkTransaction(), cond::persistency::GTProxy::checkTransaction(), cond::persistency::IOVProxy::checkTransaction(), convertoToOracleConnection(), copyIov(), cond::persistency::Session::coralSession(), cond::persistency::GLOBAL_TAG::Table::create(), cond::persistency::TAG::Table::create(), cond::persistency::RUN_INFO::Table::create(), cond::persistency::GLOBAL_TAG_MAP::Table::create(), cond::persistency::PAYLOAD::Table::create(), cond::persistency::IOV::Table::create(), cond::persistency::TAG_LOG::Table::create(), cond::persistency::Session::createGlobalTag(), cond::persistency::Session::createIov(), cond::persistency::Session::createIovForPayload(), cond::service::PoolDBOutputService::createNewIOV(), 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::KeyList::get(), cond::persistency::RunInfoProxy::get(), getConnectionProtocol(), cond::persistency::IOVProxy::getInterval(), cond::persistency::IOVProxy::getMetadata(), cond::persistency::Session::getRunInfo(), import(), importIovs(), MillePedeAlignmentAlgorithm::initialize(), cond::persistency::GTEditor::load(), cond::persistency::GTProxy::load(), cond::persistency::IOVProxy::load(), cond::persistency::PayloadProxy< std::vector< cond::Time_t > >::loadPayload(), cond::persistency::IOVProxy::loadRange(), 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(), Session::storePayload< std::string >(), cond::CredentialStore::setPermission(), cond::CredentialStore::startSession(), cond::persistency::SessionImpl::startTransaction(), cond::persistency::Session::storePayload(), cond::CredentialStore::updateConnection(), cond::service::PoolDBOutputService::writeOne(), and cond::persistency::Exception::~Exception().

                                          {
      throw Exception( message, methodName );
    }