cond Namespace Reference

Namespaces
	auth
	persistency
	RelationalAuthenticationService
	serialization
	service
	time
	utilities
	XMLAuthenticationService

Classes
struct	AuthorizationData
class	BaseKeyed
class	BasicPayload
class	Binary
class	CoralServiceFactory
class	CoralServiceManager
struct	CredentialData
class	CredentialStore
class	CSScopedSession
class	DataProxyWrapperBase
struct	DefaultInitializer
class	EmptyIOVSource
class	FileReader
class	GenericSummary
class	GTEntry_t
struct	GTMetadata_t
struct	Iov_t
class	IOVDescription
class	IOVKeysDescription
class	IOVProvenance
class	IOVUserMetaData
class	KeyedElement
struct	LessFrame
struct	LogDBEntry_t
struct	PrincipalData
struct	RealTimeType
struct	RealTimeType< hash >
struct	RealTimeType< lumiid >
struct	RealTimeType< runnumber >
struct	RealTimeType< timestamp >
struct	RealTimeType< userid >
class	SmallWORMDict
class	StreamerInfo
class	Summary
struct	Tag_t
struct	TagInfo_t
struct	TagMetadata_t
struct	TimeTypeSpecs
struct	TimeTypeTraits
class	UnregisteredRecordException
struct	UserLogInfo
class	Utilities
class	UtilitiesError

Typedefs
typedef cond::serialization::InputArchive	CondInputArchive
typedef cond::serialization::OutputArchive	CondOutputArchive
typedef edmplugin::PluginFactory < coral::Service *(const std::string &) >	CoralServicePluginFactory
typedef persistency::Exception	Exception
typedef ora::Guid	Guid
typedef std::string	Hash
typedef edmplugin::PluginFactory < cond::DataProxyWrapperBase *() >	ProxyFactory
typedef TagInfo_t	TagInfo
typedef unsigned long long	Time_t
typedef unsigned long long	uint64_t
typedef std::pair< unsigned int, unsigned int >	UnpackedTime
typedef std::pair< Time_t, Time_t >	ValidityInterval

Enumerations
enum	SynchronizationType {   SYNCH_ANY = 0, SYNCH_VALIDATION, SYNCH_OFFLINE, SYNCH_MC,   SYNCH_RUNMC, SYNCH_HLT, SYNCH_EXPRESS, SYNCH_PROMPT,   SYNCH_PCL }
enum	TimeType {   invalid =-1, runnumber =0, timestamp, lumiid,   hash, userid }

Functions
std::string	classNameForTypeId (const std::type_info &typeInfo)
template<typename T >
std::string	convertToXML (const std::string &payloadData, const std::string &payloadType)
template<typename T >
T *	createPayload (const std::string &payloadTypeName)
template<>
HcalCalibrationQIEData *	createPayload< HcalCalibrationQIEData > (const std::string &payloadTypeName)
template<typename T >
boost::shared_ptr< T >	default_deserialize (const std::string &payloadType, const Binary &payloadData, const Binary &streamerInfoData)
template<typename T >
boost::shared_ptr< T >	deserialize (const std::string &payloadType, const Binary &payloadData, const Binary &streamerInfoData)
template<>
boost::shared_ptr< BaseKeyed >	deserialize< BaseKeyed > (const std::string &payloadType, const Binary &payloadData, const Binary &streamerInfoData)
template<>
boost::shared_ptr < condex::Efficiency >	deserialize< condex::Efficiency > (const std::string &payloadType, const Binary &payloadData, const Binary &streamerInfoData)
template<>
boost::shared_ptr < CSCReadoutMapping >	deserialize< CSCReadoutMapping > (const std::string &payloadType, const Binary &payloadData, const Binary &streamerInfoData)
template<>
boost::shared_ptr < CSCReadoutMappingForSliceTest >	deserialize< CSCReadoutMappingForSliceTest > (const std::string &payloadType, const Binary &payloadData, const Binary &streamerInfoData)
template<>
boost::shared_ptr < PerformancePayload >	deserialize< PerformancePayload > (const std::string &payloadType, const Binary &payloadData, const Binary &streamerInfoData)
const TimeTypeSpecs &	findSpecs (std::string const &name)
void *	genMD5 (void *buffer, unsigned long len, void *code)
void	genMD5 (const std::string &s, void *code)
void	genMD5 (const string &s, void *code)
std::string	getLoginName ()
unsigned long long	hash64 (unsigned char *k, unsigned long long length, unsigned long long level)
const Time_t	invalidTime (0)
const std::string	invalidToken (" ")
Iov_t	makeIov (cond::Time_t since, const Hash &payloadId)
void	parseLineForNamedParams (const std::string &line, std::map< std::string, std::string > &params)
std::pair< std::string, int >	parseToken (const std::string &objectId)
const char *	pluginCategory ()
char	randomChar ()
std::string	schemaLabel (const std::string &serviceName, const std::string &userName)
std::string	schemaLabelForCredentialStore (const std::string &connectionString)
bool	selectAuthorization (coral::ISchema &schema, int principalId, const std::string &role, const std::string &connectionString, AuthorizationData &destination)
bool	selectConnection (coral::ISchema &schema, const std::string &connectionLabel, CredentialData &destination)
bool	selectPrincipal (coral::ISchema &schema, const std::string &principal, PrincipalData &destination)
template<typename T >
std::pair< Binary, Binary >	serialize (const T &payload)
SynchronizationType	synchronizationTypeFromName (const std::string &name)
std::string	synchronizationTypeNames (SynchronizationType type)
void	throwException (const std::string &message, const std::string &methodName)
const Time_t	TIMELIMIT (std::numeric_limits< Time_t >::max())
std::string const &	timeTypeNames (int)
std::string	writeToken (const std::string &containerName, int oid0, int oid1, const std::string &className)
std::string	writeTokenContainerFragment (const std::string &containerName, const std::string &className)

Variables
static const char *	fmt_oid = "[OID=%08X-%08X]"
static const char *	fmt_tech = "[TECH=%08X]"
static constexpr unsigned int	HASH_SIZE = 40
static std::pair< const char *, SynchronizationType >	s_obsoleteSynchronizationTypeArray []
static std::pair< const char *, SynchronizationType >	s_synchronizationTypeArray []
const unsigned int	TIMETYPE_LIST_MAX =5
const cond::TimeType	timeTypeList [TIMETYPE_LIST_MAX]
const TimeTypeSpecs	timeTypeSpecs []
const cond::TimeType	timeTypeValues []

Detailed Description

Serialization.h CondCore/CondDB/interface/Serialization.h Description: functions for serializing the payload objects.

Typedef Documentation

typedef cond::serialization::InputArchive cond::CondInputArchive

Definition at line 50 of file Serialization.h.

typedef cond::serialization::OutputArchive cond::CondOutputArchive

Definition at line 51 of file Serialization.h.

typedef edmplugin::PluginFactory< coral::Service*(const std::string&) > cond::CoralServicePluginFactory

Definition at line 24 of file CoralServiceFactory.h.

typedef persistency::Exception cond::Exception

Definition at line 25 of file Exception.h.

typedef ora::Guid cond::Guid

Definition at line 26 of file Guid.h.

typedef std::string cond::Hash

Definition at line 45 of file Types.h.

typedef edmplugin::PluginFactory< cond::DataProxyWrapperBase* () > cond::ProxyFactory

Definition at line 29 of file ProxyFactory.h.

typedef TagInfo_t cond::TagInfo

Definition at line 79 of file Types.h.

typedef unsigned long long cond::Time_t

Definition at line 16 of file Time.h.

typedef unsigned long long cond::uint64_t

Definition at line 15 of file Time.h.

typedef std::pair<unsigned int, unsigned int> cond::UnpackedTime

Definition at line 17 of file Time.h.

typedef std::pair<Time_t, Time_t> cond::ValidityInterval

Definition at line 19 of file Time.h.

Enumeration Type Documentation

enum cond::SynchronizationType

Enumerator
SYNCH_ANY
SYNCH_VALIDATION
SYNCH_OFFLINE
SYNCH_MC
SYNCH_RUNMC
SYNCH_HLT
SYNCH_EXPRESS
SYNCH_PROMPT
SYNCH_PCL

Definition at line 29 of file Types.h.

               { 
    SYNCH_ANY = 0,
    SYNCH_VALIDATION,
    SYNCH_OFFLINE,
    SYNCH_MC,
    SYNCH_RUNMC,
    SYNCH_HLT, 
    SYNCH_EXPRESS,
    SYNCH_PROMPT, 
    SYNCH_PCL 
  } SynchronizationType;

enum cond::TimeType

Enumerator
invalid
runnumber
timestamp
lumiid
hash
userid

Definition at line 21 of file Time.h.

{ invalid=-1, runnumber=0, timestamp, lumiid, hash, userid } TimeType;

Function Documentation

std::string cond::classNameForTypeId ( const std::type_info &  typeInfo )

inline

Definition at line 29 of file PoolDBOutputService.h.

References edm::TypeID::className().

                                                                     {
    edm::TypeID type( typeInfo );
    return type.className();
  }

template<typename T >

std::string cond::convertToXML	(	const std::string &	payloadData,
		const std::string &	payloadType
	)

Definition at line 21 of file PayloadToXML.h.

                                                                                       { 

      std::unique_ptr< T > payload;
      std::stringbuf sdataBuf;
      sdataBuf.pubsetbuf( const_cast<char *> ( payloadData.c_str() ), payloadData.size() );

      std::istream inBuffer( &sdataBuf );
      eos::portable_iarchive ia( inBuffer );
      payload.reset( new T );
      ia >> (*payload);

      // now we have the object in memory, convert it to xml in a string and return it
     
      std::ostringstream outBuffer;
      boost::archive::xml_oarchive xmlResult( outBuffer );
      xmlResult << boost::serialization::make_nvp( "cmsCondPayload", *payload );

      return outBuffer.str();

  }

template<typename T >

T* cond::createPayload

(

const std::string &

payloadTypeName

)

Definition at line 30 of file Serialization.h.

References ora::ClassUtils::demangledName(), AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

                                                                            {
    std::string userTypeName = demangledName( typeid(T) );
    if( userTypeName != payloadTypeName ) 
      throwException(std::string("Type mismatch, user type: \""+userTypeName+"\", target type: \"")+payloadTypeName+"\"",
             "createPayload" );
    return new T;
  }

template<>

HcalCalibrationQIEData* cond::createPayload< HcalCalibrationQIEData >

(

const std::string &

payloadTypeName

)

Definition at line 34 of file plugin.cc.

References AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

                                                                                                               {
    if( payloadTypeName == "HcalCalibrationQIEData" ) return new HcalCalibrationQIEData(0);
    throwException(std::string("Type mismatch, target object is type \"")+payloadTypeName+"\"",
           "createPayload" );
  }

template<typename T >

boost::shared_ptr<T> cond::default_deserialize	(	const std::string &	payloadType,
		const Binary &	payloadData,
		const Binary &	streamerInfoData
	)

Definition at line 73 of file Serialization.h.

References cond::Binary::data(), alignCSCRings::e, cppFunctionSkipper::exception, cond::Binary::size(), AlCaHLTBitMon_QueryRunRegistry::string, cond::StreamerInfo::techVersion(), and throwException().

                                                                  {
    boost::shared_ptr<T> payload;
    std::stringbuf sstreamerInfoBuf;
    sstreamerInfoBuf.pubsetbuf( static_cast<char*>(const_cast<void*>(streamerInfoData.data())), streamerInfoData.size() );
    std::string streamerInfo = sstreamerInfoBuf.str();
    try{
      std::stringbuf sdataBuf;
      sdataBuf.pubsetbuf( static_cast<char*>(const_cast<void*>(payloadData.data())), payloadData.size() );
      std::istream dataBuffer( &sdataBuf );
      CondInputArchive ia( dataBuffer );
      payload.reset( createPayload<T>(payloadType) );
      ia >> (*payload);
    } catch ( const std::exception& e ){
      std::string errorMsg("De-serialization failed: ");
      std::string em( e.what() );
      if( em == "unsupported version" )  {
    errorMsg += "the current boost version ("+StreamerInfo::techVersion()+
      ") is unable to read the payload. Data might have been serialized with an incompatible version.";
      } else if( em == "input stream error" ) {
    errorMsg +="data size does not fit with the current class layout. The Class "+payloadType+" might have been changed with respect to the layout used in the upload.";
      } else {
    errorMsg += em;
      }
      if( !streamerInfo.empty() ) errorMsg += " Payload serialization info: "+streamerInfo;
      throwException( errorMsg, "default_deserialize" );
    }
    return payload;
  }

template<typename T >

boost::shared_ptr<T> cond::deserialize	(	const std::string &	payloadType,
		const Binary &	payloadData,
		const Binary &	streamerInfoData
	)

Definition at line 105 of file Serialization.h.

References HLT_25ns10e33_v2_cff::payloadType.

                                                              {
    return default_deserialize<T>( payloadType, payloadData, streamerInfoData );
 }

template<>

boost::shared_ptr< BaseKeyed > cond::deserialize< BaseKeyed >	(	const std::string &	payloadType,
		const Binary &	payloadData,
		const Binary &	streamerInfoData
	)

Definition at line 39 of file plugin.cc.

References DESERIALIZE_BASE_CASE, DESERIALIZE_POLIMORPHIC_CASE, HLT_25ns10e33_v2_cff::payloadType, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

                                                                   {
    DESERIALIZE_BASE_CASE( BaseKeyed );
    DESERIALIZE_POLIMORPHIC_CASE( BaseKeyed, condex::ConfI );
    DESERIALIZE_POLIMORPHIC_CASE( BaseKeyed, condex::ConfI );

    // here we come if none of the deserializations above match the payload type:                                                                                                                                                                                             
    throwException(std::string("Type mismatch, target object is type \"")+payloadType+"\"", "deserialize<>" );
  }

template<>

boost::shared_ptr<condex::Efficiency> cond::deserialize< condex::Efficiency >	(	const std::string &	payloadType,
		const Binary &	payloadData,
		const Binary &	streamerInfoData
	)

Definition at line 25 of file plugin.cc.

References DESERIALIZE_POLIMORPHIC_CASE, HLT_25ns10e33_v2_cff::payloadType, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

                                                                                                                     {
    // DESERIALIZE_BASE_CASE( condex::Efficiency ); abstract 
    DESERIALIZE_POLIMORPHIC_CASE( condex::Efficiency, condex::ParametricEfficiencyInPt );
    DESERIALIZE_POLIMORPHIC_CASE( condex::Efficiency, condex::ParametricEfficiencyInEta );

    // here we come if none of the deserializations above match the payload type:
    throwException(std::string("Type mismatch, target object is type \"")+payloadType+"\"", "deserialize<>" );
  }

template<>

boost::shared_ptr<CSCReadoutMapping> cond::deserialize< CSCReadoutMapping >	(	const std::string &	payloadType,
		const Binary &	payloadData,
		const Binary &	streamerInfoData
	)

Definition at line 64 of file plugin.cc.

References DESERIALIZE_POLIMORPHIC_CASE, HLT_25ns10e33_v2_cff::payloadType, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

                                                                           {
    // DESERIALIZE_BASE_CASE( CSCReadoutMapping ); abstract
    DESERIALIZE_POLIMORPHIC_CASE( CSCReadoutMapping, CSCReadoutMappingFromFile );
    // here we come if none of the deserializations above match the payload type:
    throwException(std::string("Type mismatch, target object is type \"")+payloadType+"\"", "deserialize<>" );
  }

template<>

boost::shared_ptr<CSCReadoutMappingForSliceTest> cond::deserialize< CSCReadoutMappingForSliceTest >	(	const std::string &	payloadType,
		const Binary &	payloadData,
		const Binary &	streamerInfoData
	)

Definition at line 72 of file plugin.cc.

References DESERIALIZE_POLIMORPHIC_CASE, HLT_25ns10e33_v2_cff::payloadType, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

                                                                                       {
    // DESERIALIZE_BASE_CASE( CSCReadoutMappingForSliceTest ); abstract
    DESERIALIZE_POLIMORPHIC_CASE( CSCReadoutMappingForSliceTest, CSCReadoutMappingFromFile );
    // here we come if none of the deserializations above match the payload type:
    throwException(std::string("Type mismatch, target object is type \"")+payloadType+"\"", "deserialize<>" );
  }

template<>

boost::shared_ptr<PerformancePayload> cond::deserialize< PerformancePayload >	(	const std::string &	payloadType,
		const Binary &	payloadData,
		const Binary &	streamerInfoData
	)

Definition at line 17 of file PerformanceRecordPlugin.cc.

References DESERIALIZE_POLIMORPHIC_CASE, HLT_25ns10e33_v2_cff::payloadType, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

                                                                             {
    // DESERIALIZE_BASE_CASE( PerformancePayload );  abstract 
    DESERIALIZE_POLIMORPHIC_CASE( PerformancePayload, PerformancePayloadFromTFormula ); 
    DESERIALIZE_POLIMORPHIC_CASE( PerformancePayload, PerformancePayloadFromBinnedTFormula ); 
    DESERIALIZE_POLIMORPHIC_CASE( PerformancePayload, PerformancePayloadFromTable ); 
    // here we come if none of the deserializations above match the payload type:
    throwException(std::string("Type mismatch, target object is type \"")+payloadType+"\"",
           "createPayload" );
  }

const TimeTypeSpecs & cond::findSpecs

(

std::string const &

name

)

Definition at line 33 of file Time.cc.

References Exception, i, TIMETYPE_LIST_MAX, and timeTypeSpecs.

Referenced by cond::time::timeTypeFromName().

                                                          {
    size_t i=0;
    for (; i<TIMETYPE_LIST_MAX; i++)
      if (name==timeTypeSpecs[i].name) return timeTypeSpecs[i];
    throw cms::Exception("invalid timetype: "+name);
    return timeTypeSpecs[0]; // compiler happy
  }

void * cond::genMD5	(	void *	buffer,
		unsigned long	len,
		void *	code
	)

Definition at line 358 of file GenMD5.cc.

Referenced by writeTokenContainerFragment().

                                                              {
    MD5 checkSum((unsigned char*)buffer, len);
    checkSum.raw_digest((unsigned char*)code);
    return code;
  }

void cond::genMD5	(	const std::string &	s,
		void *	code
	)

void cond::genMD5	(	const string &	s,
		void *	code
	)

Definition at line 363 of file GenMD5.cc.

                                              {
    MD5 checkSum((unsigned char*)s.c_str(), s.length());
    checkSum.raw_digest((unsigned char*)code);
  }

std::string cond::getLoginName

(

)

Definition at line 41 of file DecodingKey.cc.

References visualization-live-secondInstance_cfg::msg, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

Referenced by cond::auth::DecodingKey::init().

                          {
    std::string loginName("");
    struct passwd* userp = ::getpwuid(::getuid());
    if(userp) {
      char* uName = userp->pw_name;
      if(uName){
    loginName += uName;
      }
    }
    if(loginName.empty()){
      std::string  msg("Cannot determine login name.");
      throwException(msg,"DecodingKey::getLoginName");     
    }
    return loginName;
  }

ub8 cond::hash64	(	unsigned char *	k,
		unsigned long long	length,
		unsigned long long	level
	)

Definition at line 45 of file hash64.cc.

References a, b, EnergyCorrector::c, testEve_cfg::level, and mix64.

Referenced by cond::KeyedElement::convert().

  {
    register ub8 a,b,c,len;
    
    /* Set up the internal state */
    len = length;
    a = b = level;                         /* the previous hash value */
    c = 0x9e3779b97f4a7c13LL; /* the golden ratio; an arbitrary value */
    
    /*---------------------------------------- handle most of the key */
    if (((unsigned long)k)&7)
      {
    while (len >= 24)
      {
        a += (k[0]        +((ub8)k[ 1]<< 8)+((ub8)k[ 2]<<16)+((ub8)k[ 3]<<24)
          +((ub8)k[4 ]<<32)+((ub8)k[ 5]<<40)+((ub8)k[ 6]<<48)+((ub8)k[ 7]<<56));
        b += (k[8]        +((ub8)k[ 9]<< 8)+((ub8)k[10]<<16)+((ub8)k[11]<<24)
          +((ub8)k[12]<<32)+((ub8)k[13]<<40)+((ub8)k[14]<<48)+((ub8)k[15]<<56));
        c += (k[16]       +((ub8)k[17]<< 8)+((ub8)k[18]<<16)+((ub8)k[19]<<24)
          +((ub8)k[20]<<32)+((ub8)k[21]<<40)+((ub8)k[22]<<48)+((ub8)k[23]<<56));
        mix64(a,b,c);
        k += 24; len -= 24;
      }
      }
    else
      {
    while (len >= 24)    /* aligned */
      {
        a += *(ub8 *)(k+0);
        b += *(ub8 *)(k+8);
        c += *(ub8 *)(k+16);
        mix64(a,b,c);
        k += 24; len -= 24;
      }
      }
    
    /*------------------------------------- handle the last 23 bytes */
    c += length;
    switch(len)              /* all the case statements fall through */
      {
      case 23: c+=((ub8)k[22]<<56);
      case 22: c+=((ub8)k[21]<<48);
      case 21: c+=((ub8)k[20]<<40);
      case 20: c+=((ub8)k[19]<<32);
      case 19: c+=((ub8)k[18]<<24);
      case 18: c+=((ub8)k[17]<<16);
      case 17: c+=((ub8)k[16]<<8);
    /* the first byte of c is reserved for the length */
      case 16: b+=((ub8)k[15]<<56);
      case 15: b+=((ub8)k[14]<<48);
      case 14: b+=((ub8)k[13]<<40);
      case 13: b+=((ub8)k[12]<<32);
      case 12: b+=((ub8)k[11]<<24);
      case 11: b+=((ub8)k[10]<<16);
      case 10: b+=((ub8)k[ 9]<<8);
      case  9: b+=((ub8)k[ 8]);
      case  8: a+=((ub8)k[ 7]<<56);
      case  7: a+=((ub8)k[ 6]<<48);
      case  6: a+=((ub8)k[ 5]<<40);
      case  5: a+=((ub8)k[ 4]<<32);
      case  4: a+=((ub8)k[ 3]<<24);
      case  3: a+=((ub8)k[ 2]<<16);
      case  2: a+=((ub8)k[ 1]<<8);
      case  1: a+=((ub8)k[ 0]);
    /* case 0: nothing left to add */
      }
    mix64(a,b,c);
    /*-------------------------------------------- report the result */
    return c;
  }

const Time_t cond::invalidTime

(

0

)

Referenced by cond::TimeTypeTraits< type >::specs().

const std::string cond::invalidToken

(

" "

)

Iov_t cond::makeIov	(	cond::Time_t	since,
		const Hash &	payloadId
	)

Definition at line 20 of file CondDBPyWrappers.cc.

References cond::Iov_t::payloadId, runTheMatrix::ret, and cond::Iov_t::since.

Referenced by BOOST_PYTHON_MODULE().

                                                          {
    Iov_t ret;
    ret.since = since;
    ret.payloadId = payloadId;
    return ret;
  }

void cond::parseLineForNamedParams	(	const std::string &	line,
		std::map< std::string, std::string > &	params
	)

Definition at line 57 of file DecodingKey.cc.

References ItemSeparator, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by cond::auth::DecodingKey::createFromInputFile().

                                                                                            {
    std::stringstream str( line );
    std::string paramName("");
    std::string paramValue("");  
    while( str.good() ){
      std::string item("");
      getline( str, item, ItemSeparator);
      if( item.size()>3 ){
    paramName = item.substr(0,2);
    paramValue = item.substr(2);
    params.insert( std::make_pair( paramName, paramValue ) );
      }  
    }
  }

std::pair< std::string, int > cond::parseToken

(

const std::string &

objectId

)

Definition at line 16 of file PoolToken.cc.

References fmt_oid, p1, p2, p3, source, AlCaHLTBitMon_QueryRunRegistry::string, ora::throwException(), and tmp.

Referenced by ora::CondMetadataTable::getObjectByName().

                                                              {
    if( source.empty() ) ora::throwException("Provided token is empty.","PoolToken::parseToken");
    std::string tmp = source;
    std::pair<std::string,int> oid;
    oid.first = "";
    oid.second = -1;
    for(char* p1 = (char*)tmp.c_str(); p1; p1 = ::strchr(++p1,'[')) {
      char* p2 = ::strchr(p1, '=');
      char* p3 = ::strchr(p1, ']');
      if ( p2 && p3 )   {
        char* val = p2+1;
        if ( ::strncmp("[DB=", p1, 4) == 0 )  {
          *p3 = 0;
        } else if ( ::strncmp("[CNT=", p1, 5) == 0 )  {
          *p3 = 0;
          oid.first = val;
        } else if ( ::strncmp(fmt_oid, p1, 5) == 0 )  {
          int nn;
          ::sscanf(p1, fmt_oid, &nn, &oid.second);
        } else    {
          *p3 = *p2 = 0;
        }
        *p3 = ']';
        *p2 = '=';
      }
    }
    return oid;
  }

const char * cond::pluginCategory

(

)

Definition at line 33 of file ProxyFactory.cc.

  {
    return  "CondProxyFactory";
  }

char cond::randomChar

(

)

Definition at line 36 of file DecodingKey.cc.

References b64str, and rand().

Referenced by cond::auth::KeyGenerator::make().

                   {
    int irand = ::rand()%(::strlen(b64str));
    return b64str[irand];
  }

std::string cond::schemaLabel	(	const std::string &	serviceName,
		const std::string &	userName
	)

std::string defaultConnectionString( const std::string& serviceConnectionString, const std::string& serviceName, const std::string& userName ){ size_t pos = serviceConnectionString.find( serviceName ); std::string technologyPrefix = serviceConnectionString.substr(0,pos); std::stringstream connStr; connStr << technologyPrefix; if( !userName.empty() ) connStr <<"/"<< userName; return connStr.str(); }

Definition at line 164 of file CredentialStore.cc.

References runTheMatrix::ret, serviceName, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by cond::CredentialStore::importForPrincipal(), and schemaLabelForCredentialStore().

                                          {
    std::string ret = userName;
    if( !serviceName.empty() ){
      ret += "@"+serviceName;
    }
    return ret;
  }

std::string cond::schemaLabelForCredentialStore

(

const std::string &

connectionString

)

Definition at line 172 of file CredentialStore.cc.

References mps_alisetup::parser, schemaLabel(), serviceName, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by cond::CredentialStore::installAdmin(), and cond::CredentialStore::updatePrincipal().

                                                                              {
    coral::URIParser parser;
    parser.setURI( connectionString );
    std::string serviceName = parser.hostName();
    std::string schemaName = parser.databaseOrSchemaName();
    return schemaLabel( serviceName, schemaName );
  }

bool cond::selectAuthorization	(	coral::ISchema &	schema,
		int	principalId,
		const std::string &	role,
		const std::string &	connectionString,
		AuthorizationData &	destination
	)

Definition at line 301 of file CredentialStore.cc.

References AUTH_ID_COL(), AUTH_KEY_COL(), C_ID_COL(), COND_AUTHORIZATION_TABLE(), cond::AuthorizationData::connectionId, newFWLiteAna::found, cond::AuthorizationData::id, cond::AuthorizationData::key, P_ID_COL(), o2o::query, ROLE_COL(), SCHEMA_COL(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by cond::CredentialStore::setPermission().

                                                                                                                                                             {
    std::auto_ptr<coral::IQuery> query(schema.tableHandle(COND_AUTHORIZATION_TABLE).newQuery());
    coral::AttributeList readBuff;
    readBuff.extend<int>(AUTH_ID_COL);
    readBuff.extend<int>(C_ID_COL);
    readBuff.extend<std::string>(AUTH_KEY_COL);
    coral::AttributeList whereData;
    whereData.extend<int>(P_ID_COL);
    whereData.extend<std::string>(ROLE_COL);
    whereData.extend<std::string>(SCHEMA_COL);
    whereData[ P_ID_COL ].data<int>() = principalId;
    whereData[ ROLE_COL ].data<std::string>() = role;
    whereData[ SCHEMA_COL ].data<std::string>() = connectionString;
    std::stringstream whereClause;
    whereClause << P_ID_COL << " = :"<<P_ID_COL;
    whereClause << " AND " << ROLE_COL << " = :"<<ROLE_COL;
    whereClause << " AND " << SCHEMA_COL << " = :"<<SCHEMA_COL;
    query->defineOutput(readBuff);
    query->addToOutputList( AUTH_ID_COL );
    query->addToOutputList( C_ID_COL );
    query->addToOutputList( AUTH_KEY_COL );
    query->setCondition( whereClause.str(), whereData );
    coral::ICursor& cursor = query->execute();
    bool found = false;
    if ( cursor.next() ) {
      const coral::AttributeList& row = cursor.currentRow();
      destination.id = row[AUTH_ID_COL].data<int>();  
      destination.connectionId = row[C_ID_COL].data<int>();
      destination.key = row[AUTH_KEY_COL].data<std::string>();
      found = true;
    }
    return found;
  }

bool cond::selectConnection	(	coral::ISchema &	schema,
		const std::string &	connectionLabel,
		CredentialData &	destination
	)

Definition at line 257 of file CredentialStore.cc.

References COND_CREDENTIAL_TABLE(), CONNECTION_ID_COL(), CONNECTION_KEY_COL(), CONNECTION_LABEL_COL(), cond::CredentialData::connectionKey, newFWLiteAna::found, cond::CredentialData::id, cond::CredentialData::password, PASSWORD_COL(), o2o::query, AlCaHLTBitMon_QueryRunRegistry::string, cond::CredentialData::userName, USERNAME_COL(), VERIFICATION_KEY_COL(), and cond::CredentialData::verificationKey.

Referenced by cond::CredentialStore::removeConnection(), cond::CredentialStore::setPermission(), cond::CredentialStore::updateConnection(), and cond::CredentialStore::updatePrincipal().

                                                                                                              {
    
    std::auto_ptr<coral::IQuery> query(schema.tableHandle(COND_CREDENTIAL_TABLE).newQuery());
    coral::AttributeList readBuff;
    readBuff.extend<int>( CONNECTION_ID_COL );
    readBuff.extend<std::string>( USERNAME_COL );
    readBuff.extend<std::string>( PASSWORD_COL );
    readBuff.extend<std::string>( VERIFICATION_KEY_COL );
    readBuff.extend<std::string>( CONNECTION_KEY_COL );
    coral::AttributeList whereData;
    whereData.extend<std::string>( CONNECTION_LABEL_COL );
    whereData[ CONNECTION_LABEL_COL ].data<std::string>() = connectionLabel;
    std::string whereClause = CONNECTION_LABEL_COL + " = :" + CONNECTION_LABEL_COL;
    query->defineOutput(readBuff);
    query->addToOutputList( CONNECTION_ID_COL );
    query->addToOutputList( USERNAME_COL );
    query->addToOutputList( PASSWORD_COL );
    query->addToOutputList( VERIFICATION_KEY_COL );
    query->addToOutputList( CONNECTION_KEY_COL );
    query->setCondition( whereClause, whereData );
    coral::ICursor& cursor = query->execute();
    bool found = false;
    if ( cursor.next() ) {
      const coral::AttributeList& row = cursor.currentRow();
      destination.id = row[ CONNECTION_ID_COL].data<int>();
      destination.userName = row[ USERNAME_COL].data<std::string>();
      destination.password = row[ PASSWORD_COL].data<std::string>();
      destination.verificationKey = row[ VERIFICATION_KEY_COL].data<std::string>();
      destination.connectionKey = row[ CONNECTION_KEY_COL].data<std::string>();
      found = true;
    }
    return found;
  }

bool cond::selectPrincipal	(	coral::ISchema &	schema,
		const std::string &	principal,
		PrincipalData &	destination
	)

Definition at line 213 of file CredentialStore.cc.

References ADMIN_KEY_COL(), cond::PrincipalData::adminKey, COND_AUTHENTICATION_TABLE(), newFWLiteAna::found, cond::PrincipalData::id, PRINCIPAL_ID_COL(), PRINCIPAL_KEY_COL(), PRINCIPAL_NAME_COL(), cond::PrincipalData::principalKey, o2o::query, AlCaHLTBitMon_QueryRunRegistry::string, VERIFICATION_COL(), and cond::PrincipalData::verifKey.

Referenced by cond::CredentialStore::importForPrincipal(), cond::CredentialStore::installAdmin(), cond::CredentialStore::removePrincipal(), cond::CredentialStore::setPermission(), cond::CredentialStore::startSession(), cond::CredentialStore::unsetPermission(), and cond::CredentialStore::updatePrincipal().

                                                                                                      {
    std::auto_ptr<coral::IQuery> query(schema.tableHandle(COND_AUTHENTICATION_TABLE).newQuery());
    coral::AttributeList readBuff;
    readBuff.extend<int>(PRINCIPAL_ID_COL);
    readBuff.extend<std::string>(VERIFICATION_COL);
    readBuff.extend<std::string>(PRINCIPAL_KEY_COL);
    readBuff.extend<std::string>(ADMIN_KEY_COL);
    coral::AttributeList whereData;
    whereData.extend<std::string>(PRINCIPAL_NAME_COL);
    whereData[ PRINCIPAL_NAME_COL ].data<std::string>() = principal;
    std::string whereClause = PRINCIPAL_NAME_COL + " = :" + PRINCIPAL_NAME_COL;
    query->defineOutput(readBuff);
    query->addToOutputList( PRINCIPAL_ID_COL );
    query->addToOutputList( VERIFICATION_COL );
    query->addToOutputList( PRINCIPAL_KEY_COL );
    query->addToOutputList( ADMIN_KEY_COL );
    query->setCondition( whereClause, whereData );
    coral::ICursor& cursor = query->execute();
    bool found = false;
    if ( cursor.next() ) {
      found = true;
      const coral::AttributeList& row = cursor.currentRow();
      destination.id = row[ PRINCIPAL_ID_COL ].data<int>();
      destination.verifKey = row[ VERIFICATION_COL ].data<std::string>();
      destination.principalKey = row[ PRINCIPAL_KEY_COL ].data<std::string>();
      destination.adminKey = row[ ADMIN_KEY_COL ].data<std::string>();
    }
    return found;
  }

template<typename T >

std::pair<Binary,Binary> cond::serialize

(

const T &

payload

)

Definition at line 54 of file Serialization.h.

References alignCSCRings::e, cppFunctionSkipper::exception, cond::StreamerInfo::jsonString(), runTheMatrix::ret, AlCaHLTBitMon_QueryRunRegistry::string, and throwException().

Referenced by cond::persistency::Session::storePayload(), and RawEventFileWriterForBU::writeJsds().

                                                                            {
    std::pair<Binary,Binary> ret;
    std::string streamerInfo( StreamerInfo::jsonString() );
    try{
      // save data to buffers
      std::ostringstream dataBuffer;
      CondOutputArchive oa( dataBuffer );
      oa << payload;
      //TODO: avoid (2!!) copies
      ret.first.copy( dataBuffer.str() );
      ret.second.copy( streamerInfo );
    } catch ( const std::exception& e ){
      std::string em( e.what() );
      throwException("Serialization failed: "+em+". Serialization info:"+streamerInfo,"serialize");
    }
    return ret;
  }

SynchronizationType cond::synchronizationTypeFromName

(

const std::string &

name

)

Definition at line 50 of file Types.cc.

References citk::for(), i, s_obsoleteSynchronizationTypeArray, s_synchronizationTypeArray, and throwException().

Referenced by cond::persistency::GetFromRow< cond::SynchronizationType >::operator()().

                                                                          {
    for (auto const &i : s_synchronizationTypeArray)
      if (name.compare(i.first)==0) return i.second;
    for (auto const &i : s_obsoleteSynchronizationTypeArray)
      if (name.compare(i.first)==0) return i.second;
    throwException( "SynchronizationType \""+name+"\" is unknown.","synchronizationTypeFromName");
  }

std::string cond::synchronizationTypeNames

(

SynchronizationType

type

)

Definition at line 46 of file Types.cc.

References s_synchronizationTypeArray.

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

                                                               {
    return s_synchronizationTypeArray[type].first;
  }

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

Definition at line 21 of file Exception.cc.

Referenced by cond::service::PoolDBOutputService::appendSinceTime(), cond::auth::Cipher::b64decrypt(), cond::service::PoolDBOutputService::closeIOV(), cond::auth::DecodingKey::createFromInputFile(), cond::service::PoolDBOutputService::createNewIOV(), createPayload(), createPayload< HcalCalibrationQIEData >(), cond::CredentialStore::createSchema(), cond::RelationalAuthenticationService::RelationalAuthenticationService::credentials(), cond::Binary::data(), default_deserialize(), deserialize< BaseKeyed >(), deserialize< condex::Efficiency >(), deserialize< CSCReadoutMapping >(), deserialize< CSCReadoutMappingForSliceTest >(), deserialize< PerformancePayload >(), cond::auth::DecodingKey::flush(), cond::persistency::getConnectionParams(), getLoginName(), cond::CredentialStore::importForPrincipal(), cond::auth::DecodingKey::init(), cond::service::PoolDBOutputService::initDB(), cond::CredentialStore::installAdmin(), cond::persistency::KeyList::load(), cond::persistency::IOVEditor::load(), cond::service::PoolDBOutputService::lookUpRecord(), cond::CredentialStore::removeConnection(), cond::CredentialStore::removePrincipal(), serialize(), cond::CredentialStore::setPermission(), cond::CredentialStore::setUpForService(), cond::Binary::size(), synchronizationTypeFromName(), cond::CredentialStore::unsetPermission(), cond::CredentialStore::updatePrincipal(), and cond::service::PoolDBOutputService::writeOne().

                                            {
    throw Exception( message, methodName );
  }

const Time_t cond::TIMELIMIT

(

std::numeric_limits< Time_t >::

max()

)

Referenced by CondDBESSource::setIntervalFor().

std::string const & cond::timeTypeNames

(

int

i

)

Definition at line 15 of file Time.cc.

References i, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by CondDBESSource::setIntervalFor(), and cond::TimeTypeTraits< type >::specs().

                                         {
    static const std::string local[]=
      {"runnumber","timestamp","lumiid","hash","userid"};
    return local[i];
  }

std::string cond::writeToken	(	const std::string &	containerName,
		int	oid0,
		int	oid1,
		const std::string &	className
	)

Definition at line 45 of file PoolToken.cc.

References fmt_oid, AlCaHLTBitMon_QueryRunRegistry::string, runonSM::text, and writeTokenContainerFragment().

Referenced by ora::CondMetadataTable::getNamesForObject(), and ora::CondMetadataTable::setObjectName().

                                                      {
    std::string str = writeTokenContainerFragment( containerName, className );
    char text[128];
    ::sprintf(text, fmt_oid, oid0, oid1);
    str += text;
    return str;
  }

std::string cond::writeTokenContainerFragment	(	const std::string &	containerName,
		const std::string &	className
	)

Definition at line 56 of file PoolToken.cc.

References edm::TypeWithDict::byName(), fmt_tech, genMD5(), ora::ClassUtils::getClassProperty(), ora::Guid::null(), AlCaHLTBitMon_QueryRunRegistry::string, runonSM::text, and ora::Guid::toString().

Referenced by ora::CondMetadataTable::getNamesForContainer(), and writeToken().

                                                                       {
    
    char buff[20];
    std::string clguid("");
    //  first lookup the class guid in the dictionary
    edm::TypeWithDict containerType = edm::TypeWithDict::byName( className );
    if( containerType ){
      clguid = ora::ClassUtils::getClassProperty( std::string("ClassID"),containerType );
    }
    // if not found, generate one...
    if( clguid.empty() ){
      genMD5(className,buff);
      Guid* gd = reinterpret_cast<Guid*>(buff);
      clguid = gd->toString();
    }
    int tech = 0xB01;
    char text[128];
    std::string str = "[DB="+Guid::null()+"][CNT=" + containerName + "][CLID="+clguid+"]";
    ::sprintf(text, fmt_tech, tech);
    str += text;
    return str;
  }

Variable Documentation

const char* cond::fmt_oid = "[OID=%08X-%08X]"

static

Definition at line 14 of file PoolToken.cc.

Referenced by parseToken(), and writeToken().

const char* cond::fmt_tech = "[TECH=%08X]"

static

Definition at line 13 of file PoolToken.cc.

Referenced by writeTokenContainerFragment().

constexpr unsigned int cond::HASH_SIZE = 40

static

Definition at line 46 of file Types.h.

std::pair<const char *, SynchronizationType> cond::s_obsoleteSynchronizationTypeArray[]

static

Initial value:

= { std::make_pair("Offline", SYNCH_OFFLINE),
                                                   std::make_pair("HLT", SYNCH_HLT),
                                                   std::make_pair("Prompt", SYNCH_PROMPT),
                                                   std::make_pair("Pcl", SYNCH_PCL) }

Definition at line 42 of file Types.cc.

Referenced by synchronizationTypeFromName().

std::pair<const char *, SynchronizationType> cond::s_synchronizationTypeArray[]

static

Initial value:

= { std::make_pair("any", SYNCH_ANY),
                                               std::make_pair("validation", SYNCH_VALIDATION),
                                               std::make_pair("offline", SYNCH_OFFLINE),
                                               std::make_pair("mc", SYNCH_MC),
                                               std::make_pair("runmc", SYNCH_RUNMC),
                                               std::make_pair("hlt", SYNCH_HLT),
                                               std::make_pair("express", SYNCH_EXPRESS),
                                               std::make_pair("prompt", SYNCH_PROMPT),
                                               std::make_pair("pcl", SYNCH_PCL) }

Definition at line 32 of file Types.cc.

Referenced by synchronizationTypeFromName(), and synchronizationTypeNames().

const unsigned int cond::TIMETYPE_LIST_MAX =5

Definition at line 22 of file Time.h.

Referenced by findSpecs().

const cond::TimeType cond::timeTypeList

Initial value:

=
    {runnumber,timestamp,lumiid,hash,userid}

Definition at line 9 of file Time.cc.

const TimeTypeSpecs cond::timeTypeSpecs

Initial value:

= {
    TimeTypeTraits<runnumber>::specs(),
    TimeTypeTraits<timestamp>::specs(),
    TimeTypeTraits<lumiid>::specs(),
    TimeTypeTraits<hash>::specs(),
    TimeTypeTraits<userid>::specs()
  }

Definition at line 22 of file Time.cc.

Referenced by cond::service::PoolDBOutputService::beginOfTime(), RunRangeDependentPedeLabeler::buildRunRangeDependencyMap(), AlignmentProducer::endOfJob(), cond::service::PoolDBOutputService::endOfTime(), findSpecs(), MillePedeAlignmentAlgorithm::initialize(), AlignmentProducer::makeNonOverlappingRunRanges(), PCLTrackerAlProducer::makeNonOverlappingRunRanges(), CondDBESSource::setIntervalFor(), PCLTrackerAlProducer::storeAlignmentsToDB(), and cond::service::PoolDBOutputService::Record::timetypestr().

const cond::TimeType cond::timeTypeValues

Initial value:

=
    {runnumber,timestamp,lumiid,hash,userid}

Definition at line 12 of file Time.cc.