TrigConf::TrigConfCoolWriter Class Reference

Reading/Writing of trigger configuration data from/to COOL. More...

#include <TrigConfCoolWriter.h>

Collaboration diagram for TrigConf::TrigConfCoolWriter:

Public Member Functions
	TrigConfCoolWriter (const std::string &dbId, std::ostream &o=std::cout)
	constructor
	~TrigConfCoolWriter ()
	destructor
void	createSchema (int schemaVersion=0)
	Create a new schema in the COOL database.
void	recreateSchema (int schemaVersion=0)
	Create a new schema in the COOL database with prior deletion of the old one.
void	printSchema (std::ostream &o)
	Prints the schema in the COOL database.
void	printSchemaVersion (std::ostream &o)
	Prints the schema in the COOL database.
void	writeL1Payload (ValidityRange vr, const CTPConfig &ctpConfig)
void	writeHLTPayload (ValidityRange vr, const HLTFrame &hltFrame, const std::string &configSource)
void	writeMCKPayload (ValidityRange vr, unsigned int mck, std::string &release, std::string &info)
void	writeRunPayload (unsigned int runNumber, unsigned int masterConfigKey, unsigned int hltPrescaleKey, const TrigConf::ThresholdConfig &lvl1Thr, const TrigConf::CTPConfig &ctpConfig, const TrigConf::CaloInfo &caloInfo, const TrigConf::HLTFrame &hltFrame, const std::string &configSource)
	Writing run-wise configuration information the COOL database.
void	writeRunPayload (const RunRangeVec &runRanges, unsigned int masterConfigKey, unsigned int hltPrescaleKey, const TrigConf::ThresholdConfig &lvl1Thr, const TrigConf::CTPConfig &ctpConfig, const TrigConf::CaloInfo &caloInfo, const TrigConf::HLTFrame &hltFrame, const std::string &configSource)
void	writeL1MenuPayload (ValidityRange vr, const TrigConf::Menu &lvl1Menu)
	Writing L1 run-wise configuration information to the COOL database.
void	writeL1MenuPayload (const RunRangeVec &runRanges, const TrigConf::Menu &lvl1Menu)
void	writeL1CTPCoreInputMapping (ValidityRange vr, const Menu &lvl1Menu)
void	writeL1MonPayload (unsigned int runNumber, const TrigConf::Menu *lvl1Menu)
	Writing L1 run-wise monitoring configuration to COOL.
void	writeL1MonPayload (const RunRangeVec &runRanges, const TrigConf::Menu *lvl1Menu)
void	writeL1BunchGroupLBPayload (const RunRangeVec &runRanges, unsigned int bgKey, const BunchGroupSet &bgs)
	Writing LB-wise L1 bunch group definition to the COOL database.
void	writeL1BunchGroupLBPayload (ValidityRange vr, unsigned int bgKey, const BunchGroupSet &bgs)
void	writeL1BunchGroupRunPayload (ValidityRange vr, const Menu &lvl1Menu, const BunchGroupSet &bgs)
	Writing run-wise L1 bunch group names and item to bunch group mapping to COOL.
void	writeL1BunchGroupRunPayload (const RunRangeVec &runRanges, const TrigConf::Menu &lvl1Menu, const TrigConf::BunchGroupSet &bgs)
void	writeHltPrescalePayload (unsigned int runNumber, unsigned int lumiblockNumber, const TrigConf::HLTPrescaleSet &pss)
	Writing luminosityblock-wise configuration information the COOL database.
void	writeHltPrescalePayload (const RunRangeVec &runRanges, const TrigConf::HLTPrescaleSet &pss)
void	writeHltPrescalePayload (cool::ValidityKey since, cool::ValidityKey until, const TrigConf::HLTPrescaleSet &pss)
void	writeL1PrescalePayload (unsigned int runNumber, unsigned int lumiblockNumber, unsigned int lvl1PrescaleKey, const TrigConf::PrescaleSet &prescale)
	Writing luminosityblock-wise configuration information the COOL database.
void	writeL1PrescalePayload (const RunRangeVec &runRanges, unsigned int lvl1PrescaleKey, const TrigConf::PrescaleSet &prescale)
void	writeL1PrescalePayload (cool::ValidityKey since, cool::ValidityKey until, unsigned int lvl1PrescaleKey, const TrigConf::PrescaleSet &prescaleSet)
void	readRunPayload (unsigned int runNumber, TrigConf::HLTFrame &hltFrame, unsigned int &masterConfigKey, unsigned int &hltPrescaleKey, std::string &configSource)
	Reading run-wise configuration information from COOL database.
void	readHLTPayload (unsigned int run, HLTFrame &hltFrame)
void	readL1Payload (unsigned int run, CTPConfig &ctpc)
void	readHltPrescalePayload (unsigned int runNumber, unsigned int lumiblockNumber, TrigConf::HLTPrescaleSet &pss)
	Reading luminosityblock-wise configuration information the COOL database.
void	readL1BunchGroupLBPayload (unsigned int runNumber, unsigned int lumiblockNumber, int &bgKey, TrigConf::BunchGroupSet &bgs)
	Reading lb-wise bunch group configuration information from COOL database.
std::pair< std::vector< std::string >, std::map< unsigned int, unsigned char > >	readL1BunchGroupRunPayload (unsigned int runNumber)
	Reading bunch group configuration information from COOL database.
void	readL1PrescalePayload (unsigned int runNumber, unsigned int lumiblockNumber, unsigned int &lvl1PrescaleKey, TrigConf::PrescaleSet &prescale)
	Reading luminosityblock-wise configuration information the COOL database.
void	readL1InputMapPayload (unsigned int runNumber, std::vector< TrigConf::PIT * > &pits, std::vector< TrigConf::TIP * > &tips)
	Read run-wise PIT configuration from COOL database.
void	readL1MonMapPayload (unsigned int runNumber, std::vector< TrigConf::ThresholdMonitor * > &mons)
	Read run-wise LVL1 monitoring configuration from COOL database.
void	readL1Items (unsigned int runNumber, std::vector< TrigConf::TriggerItem * > &items)
	Read run-wise L1 item vector from COOL database.
void	readL1Thresholds (unsigned int runNumber, std::vector< TrigConf::TriggerThreshold * > &thrs)
	Read run-wise L1 threshold vector from COOL database.
void	readL1ItemDef (unsigned int runNumber, const std::vector< TrigConf::TriggerItem * > &items, const std::vector< TrigConf::TriggerThreshold * > &thrs)
	Read run-wise L1 item defintions (conditions) from COOL database.
void	readL1Menu (unsigned int runNumber, CTPConfig &ctpc)
	Read L1 menu from COOL database.
std::vector< std::string >	checkPayloadSize (unsigned int run, unsigned int lb, int displayMode, bool openend, unsigned int lbend)
void	addWriteFolder (const std::string &fname)
void	setVerbosityLevel (unsigned int level)
unsigned int	verbosityLevel () const
bool	checkDbConnection (bool readonly)
bool	HLTPrescaleFolderExists ()
void	clearWriteFolder ()

Private Member Functions
	TrigConfCoolWriter ()
	default constructor
	TrigConfCoolWriter (const TrigConfCoolWriter &orig)
	copy constructor
cool::IDatabaseSvc &	databaseService ()
	get COOL db service
cool::IDatabasePtr	openDb (bool readOnly=true)
	open COOL db connection
bool	dbIsOpen ()
	check if db is open
void	dropDb ()
	delete the COOL database
void	closeDb (cool::IDatabasePtr &db)
	close the COOL database
void	closeDb ()
cool::IDatabasePtr	createDb ()
	create a new COOL database
cool::IDatabasePtr	recreateDb ()
	create a new COOL database with prior deletion of the old one
void	rangeInfo (const std::string &content, cool::ValidityKey since, cool::ValidityKey until)
bool	shouldFolderBeUpdated (const std::string &foldername)
	check if foldername is in list of writeable folders

Private Attributes
cool::DatabaseId	m_dbId
	db connection string
cool::IDatabasePtr	m_dbPtr
	COOL database pointer.
cool::Application	m_coolApp
	COOL application.
std::vector< std::string >	m_writeFolderList
	list of folders to which writing is restricted
std::ostream &	m_ostream
	output stream for all messages
int	m_verbosityLevel {0}

Friends
class	AutoDBOpen

Detailed Description

Reading/Writing of trigger configuration data from/to COOL.

Definition at line 95 of file TrigConfCoolWriter.h.

Constructor & Destructor Documentation

TrigConfCoolWriter() [1/3]

TrigConf::TrigConfCoolWriter::TrigConfCoolWriter ( const std::string & dbId, std::ostream & o = std::cout )

inline

constructor

Parameters

dbId	database connection string
o	output stream for all messages (defaults to cout)

Definition at line 103 of file TrigConfCoolWriter.h.

                                                                          : 
         m_dbId(cool::DatabaseId(dbId)),
         m_writeFolderList(),
         m_ostream(o)
      {}

~TrigConfCoolWriter()

TrigConf::TrigConfCoolWriter::~TrigConfCoolWriter ( )

inline

destructor

Definition at line 110 of file TrigConfCoolWriter.h.

{};  

TrigConfCoolWriter() [2/3]

TrigConf::TrigConfCoolWriter::TrigConfCoolWriter ( )

inlineprivate

default constructor

Definition at line 393 of file TrigConfCoolWriter.h.

                          :
         m_ostream(std::cout)
      {};

TrigConfCoolWriter() [3/3]

TrigConf::TrigConfCoolWriter::TrigConfCoolWriter ( const TrigConfCoolWriter & orig )

inlineprivate

copy constructor

Definition at line 398 of file TrigConfCoolWriter.h.

                                                          :
         m_ostream(orig.m_ostream)
      {};

Member Function Documentation

addWriteFolder()

void TrigConf::TrigConfCoolWriter::addWriteFolder ( const std::string & fname )

inline

Definition at line 378 of file TrigConfCoolWriter.h.

{ m_writeFolderList.push_back( fname ); }

checkDbConnection()

bool TrigConf::TrigConfCoolWriter::checkDbConnection

(

bool

readonly

)

Definition at line 88 of file TrigConfCoolWriter.cxx.

                                                             {
   if(dbIsOpen()) return true;
   openDb( readOnly );
   closeDb();
   return true;
}

checkPayloadSize()

vector< string > TrigConf::TrigConfCoolWriter::checkPayloadSize	(	unsigned int	run,
		unsigned int	lb,
		int	displayMode,
		bool	openend,
		unsigned int	lbend )

Definition at line 1701 of file TrigConfCoolWriter.cxx.

                                                                                                                                 {
   AutoDBOpen db(this, READ_ONLY);
 
 
   ValidityRange vr(run);
   
   if(openend) {
       vr = ValidityRange(run, lb);
   } else {
       ValidityKey since(run); since <<= 32; since += lb;
       ValidityKey until(run); until <<= 32; until += lbend+1;
       vr = ValidityRange(since, until);
   }
   m_ostream << "Checking for run " << run << " and lb range " << (vr.since() & 0xFFFFFFFF) << " - " << ( (vr.until()-1) & 0xFFFFFFFF) << endl
             << endl
             << "    Folder                                     Payload Size" << endl
             << "================================================================================" << endl;
 
   vector<string> foldersToFix;
 
   vector<string>  folderList = { 
      "/TRIGGER/LVL1/Menu",
      "/TRIGGER/LVL1/ItemDef",
      "/TRIGGER/LVL1/Thresholds",
      "/TRIGGER/LVL1/CTPCoreInputMapping",
      "/TRIGGER/LVL1/Lvl1ConfigKey",
      "/TRIGGER/LVL1/Prescales",
      "/TRIGGER/LVL1/BunchGroupKey",
      "/TRIGGER/LVL1/BunchGroupContent",
      "/TRIGGER/LVL1/BunchGroupDescription",
      "/TRIGGER/HLT/HltConfigKeys",
      "/TRIGGER/HLT/Menu",
      "/TRIGGER/HLT/Groups",
      "/TRIGGER/HLT/PrescaleKey",
      "/TRIGGER/HLT/Prescales"
   };
   
   for(const string & folderName : folderList) {
      IFolderPtr folder = m_dbPtr->getFolder( folderName );
      unsigned int size = folder->countObjects( vr.since(), vr.until()-1, ChannelSelection() );
      bool isSingleVersion = folder->versioningMode()==FolderVersioning::SINGLE_VERSION;
      bool needsFixing = (size == 0);
 
      bool displayFixing = false;
      if(displayMode==1) { // only allow fixing of folders that are empty
         displayFixing = (size == 0);
      } else if(displayMode==2) { // allow fixing of folders that are empty or mv
         displayFixing = (size == 0) || !isSingleVersion;
      }
 
      string fn = folderName + (isSingleVersion ? " (sv)" : " (mv)");
      if(displayFixing) {
         m_ostream << setw(2) << foldersToFix.size()+1 << ") ";
         foldersToFix.push_back(folderName);
      } else {
         m_ostream << "    ";
      }
      m_ostream << left << setw(40) << fn << right << setw(15) << size << "            " << ( needsFixing ? "NEEDS FIX" : "       OK") << endl;
   }
 
   return foldersToFix;
 
}

clearWriteFolder()

void TrigConf::TrigConfCoolWriter::clearWriteFolder ( )

inline

Definition at line 387 of file TrigConfCoolWriter.h.

{ m_writeFolderList.clear(); }

closeDb() [1/2]

void TrigConf::TrigConfCoolWriter::closeDb ( )

private

Definition at line 155 of file TrigConfCoolWriter.cxx.

                                    {
   try {
      if(dbIsOpen()) {
         m_ostream << "Closing database '" << m_dbId << "'" << endl;
         m_dbPtr->closeDatabase();
      }
   } catch(std::exception& e) {
      m_ostream << "*** COOL  exception caught: " << e.what() << endl 
                << "Couldn't close conditions database: " << m_dbId << endl;
   }
}

closeDb() [2/2]

void TrigConf::TrigConfCoolWriter::closeDb ( cool::IDatabasePtr & db )

private

close the COOL database

Definition at line 137 of file TrigConfCoolWriter.cxx.

                                                        {
   try {
      if(db.use_count()>0 && db->isOpen()) {
         m_ostream << "Closing database (old way) '" << m_dbId << "'" << endl;
         db->closeDatabase( );
      }
   } catch(std::exception& e) {
      m_ostream << "*** COOL  exception caught: " << e.what() << endl 
                << "Couldn't close conditions database: " << m_dbId << endl;
   }
   return;
}

createDb()

cool::IDatabasePtr TrigConf::TrigConfCoolWriter::createDb ( )

private

create a new COOL database

Definition at line 245 of file TrigConfCoolWriter.cxx.

                                     {
   m_ostream << "Creating database '" << m_dbId << "'" << endl;
   try {
      cool::IDatabaseSvc& dbSvc = databaseService();
      m_dbPtr = dbSvc.createDatabase( m_dbId );
   }
   catch(std::exception& e) {
      m_ostream << "*** COOL  exception caught: " << e.what() << endl;
      m_ostream << "Coudn't create a new conditions database: " << m_dbId << endl;
      throw;
   }
 
   return m_dbPtr;
}

createSchema()

void TrigConf::TrigConfCoolWriter::createSchema

(

int

schemaVersion = 0

)

Create a new schema in the COOL database.

Definition at line 172 of file TrigConfCoolWriter.cxx.

                                                          {
   bool needToOpen = !dbIsOpen();
   if(needToOpen) {
      try {
         openDb(false);
      }
      catch(cool::DatabaseDoesNotExist& e) {
         m_ostream << "*** : " << e.what() << endl;
         m_ostream << "Will create a new database: " << m_dbId << endl;
         createDb();
         openDb(false);
      }
      catch(cool::Exception& e) {
         m_ostream << "*** COOL  exception caught: " << e.what() << endl;
         m_ostream << "Coudn't create a new schema: " << m_dbId << endl;
         throw;
      }
   }
 
   try {
      if(schemaVersion==0) schemaVersion=TrigConfCoolFolderSpec::getDefaultSchemaVersion();
      m_ostream << "Creating schema '" << m_dbId << "' with version " << schemaVersion
                << (schemaVersion==TrigConfCoolFolderSpec::getDefaultSchemaVersion()?" (=default)":"") << endl;
      TrigConfCoolFolderSpec::createFolderStructure(m_dbPtr, schemaVersion);
   }
   catch(cool::Exception& e) {
      m_ostream << "*** COOL  exception caught: " << e.what() << endl;
      m_ostream << "Coudn't create a new schema: " << m_dbId << endl;
      throw;
   }
   if(needToOpen) closeDb();
   return;
}

databaseService()

cool::IDatabaseSvc & TrigConfCoolWriter::databaseService ( )

private

get COOL db service

Definition at line 81 of file TrigConfCoolWriter.cxx.

{
   return m_coolApp.databaseService();
}

dbIsOpen()

bool TrigConf::TrigConfCoolWriter::dbIsOpen ( )

private

check if db is open

Definition at line 97 of file TrigConfCoolWriter.cxx.

                                     { 
   return m_dbPtr.use_count()>0 && m_dbPtr->isOpen();
}

dropDb()

void TrigConf::TrigConfCoolWriter::dropDb ( )

private

delete the COOL database

Definition at line 238 of file TrigConfCoolWriter.cxx.

{}

HLTPrescaleFolderExists()

bool TrigConf::TrigConfCoolWriter::HLTPrescaleFolderExists

(

)

Definition at line 1683 of file TrigConfCoolWriter.cxx.

                                                    {
   AutoDBOpen db(this, READ_ONLY);
   return m_dbPtr->existsFolder( "/TRIGGER/HLT/Prescales" );
}

openDb()

cool::IDatabasePtr TrigConf::TrigConfCoolWriter::openDb ( bool readOnly = true )

private

open COOL db connection

Parameters

readOnly

if true the db is opened in readonly mode

Definition at line 106 of file TrigConfCoolWriter.cxx.

                                                  {
   if(dbIsOpen()) return m_dbPtr;
   cool::IDatabaseSvc& dbSvc = databaseService();
   try {
      m_ostream << "Opening database '" << m_dbId << "' in " << (readOnly?"read-only":"read-write") << " mode" << endl;
      m_dbPtr = dbSvc.openDatabase( m_dbId, readOnly );   // If the database does not exist, an exception is thrown
      //     int schemaVersion = TrigConfCoolFolderSpec::readSchemaVersion(m_dbPtr);
      //     m_ostream << "Found schema with version " << schemaVersion << endl;
      return m_dbPtr;
   } catch(cool::DatabaseDoesNotExist& e) {
      if(readOnly) {
         m_ostream << "Database '" << m_dbId << "' does not exist. Can't create it since connection is read-only." << endl;
         throw;
      } else {
         m_ostream << "Database '" << m_dbId << "' does not exist, will create it" << endl;
         m_dbPtr = dbSvc.createDatabase( m_dbId );
         m_ostream << "Created DB" << endl;
         return m_dbPtr;
      }
   } catch(Exception& e) {
      m_ostream << "*** COOL exception caught: " << e.what() << endl;
      m_ostream << "Couldn't open database " << m_dbId << endl;
      throw;
   }
}

printSchema()

void TrigConf::TrigConfCoolWriter::printSchema

(

std::ostream &

o

)

Prints the schema in the COOL database.

Parameters

o	output stream

Definition at line 211 of file TrigConfCoolWriter.cxx.

                                                      {
   AutoDBOpen db(this, READ_ONLY);
   TrigConfCoolFolderSpec::printFolderStructure(m_dbPtr, o);
}

printSchemaVersion()

void TrigConf::TrigConfCoolWriter::printSchemaVersion

(

std::ostream &

o

)

Prints the schema in the COOL database.

Parameters

o	output stream

Definition at line 221 of file TrigConfCoolWriter.cxx.

                                                             {
   AutoDBOpen db(this, READ_ONLY);
   int schemaVersion = TrigConfCoolFolderSpec::readSchemaVersion(m_dbPtr);
   o << "Schema version is " << schemaVersion
     << (schemaVersion==TrigConfCoolFolderSpec::getDefaultSchemaVersion()?" (=default)":"") << endl;
}

rangeInfo()

void TrigConfCoolWriter::rangeInfo ( const std::string & content, cool::ValidityKey since, cool::ValidityKey until )

private

Definition at line 262 of file TrigConfCoolWriter.cxx.

                                                     {
 
 
   if(since==ValidityKeyMin && until==ValidityKeyMax) {
      m_ostream << "Writing " << content << " for infinite range [0,oo]" << endl;
      return;
   }
 
   unsigned long long run[2];
   unsigned long long lb[2];
   lb[0] = since & 0xFFFFFFFF;
   lb[1] = until & 0xFFFFFFFF;
   run[0] = since>>32;
   run[0] &= 0x7FFFFFFF;
   run[1] = until>>32;
   run[1] &= 0x7FFFFFFF;
 
   if(lb[0]==0 && lb[1]==0) {
      unsigned int first = run[0];
      unsigned int last  = run[1]-1;
      if(first==last) {
         m_ostream << "IOV Info: writing " << content << " for run " << first << endl;
      } else {
         m_ostream << "IOV Info: writing " << content << " for run range [" << first << "," << last << "]" << endl;
      }
   } else {
      if(run[0]==run[1]) {
         if(lb[0]==lb[1]-1)
            m_ostream << "IOV Info: writing " << content << " for run " << run[0] << " and LB " << lb[0] << endl;
         else
            m_ostream << "IOV Info: writing " << content << " for run " << run[0] << " and LB range [" << lb[0] << "," << lb[1]-1 << "]" << endl;
      } else {
         m_ostream << "IOV Info: writing " << content << " for range [" << run[0] << "/" << lb[0] << "," << run[1] << "/" << lb[1] << "[" << endl;
      }
   }
}

readHLTPayload()

void TrigConfCoolWriter::readHLTPayload	(	unsigned int	run,
		HLTFrame &	hltFrame )

Definition at line 1249 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_ONLY);
   ValidityKey pointInTime( (ValidityKey(run)<<32) + 1);
 
   // read the general chain info
   IFolderPtr hltMenuFolder = TrigConfCoolFolderSpec::getHltMenuFolder(m_dbPtr);
   IObjectIteratorPtr objects = hltMenuFolder->findObjects( pointInTime, ChannelSelection() );
   while ( objects->goToNext() ) {
      const IObject& obj = objects->currentRef();
      const IRecord & payload = obj.payload();
      HLTChain* ch = createHLTChain( payload.attributeList(), &hltFrame.theHLTSequenceList() );
      hltFrame.theHLTChainList().addHLTChain(ch);
   }
 
   // read the chain groups (they are in a separate folder)
   IFolderPtr hltGroupFolder = TrigConfCoolFolderSpec::getHltChainGroupFolder(m_dbPtr);
   objects = hltGroupFolder->findObjects( pointInTime, ChannelSelection() );
   while ( objects->goToNext() ) {
      const IObject& obj = objects->currentRef();
      const IRecord & payload = obj.payload();
      addGroupsToHltChain( payload.attributeList(), hltFrame.theHLTChainList());
   }
 
   IFolderPtr hltConfigKeyFolder = TrigConfCoolFolderSpec::getHltConfKeyFolder(m_dbPtr);
   try {
      IObjectPtr object = hltConfigKeyFolder->findObject( pointInTime, (ChannelId) 0 );
      const IRecord & payload = object->payload();
      unsigned int smk, hltPrescaleKey;
      string configSource;
      readHltConfigKeys( payload.attributeList(), smk, hltPrescaleKey, configSource ); // the hltPrescaleKey here is not useable (it is superseeded by the multiversion one)
      hltFrame.setSMK(smk);
      hltFrame.setConfigSource(configSource);
   }
   catch(const cool::ObjectNotFound& o) {
      m_ostream << "<readHLTPayload> No entry found in HLT keys folder for run " << run  << endl;
   }
}

readHltPrescalePayload()

void TrigConfCoolWriter::readHltPrescalePayload	(	unsigned int	runNumber,
		unsigned int	lumiblockNumber,
		TrigConf::HLTPrescaleSet &	pss )

Reading luminosityblock-wise configuration information the COOL database.

Parameters

runNumber	run number
lumiblockNumber	luminosity block number
pss	HLT prescale configuration object

Definition at line 1115 of file TrigConfCoolWriter.cxx.

                                                                 {
   
   AutoDBOpen db(this, READ_ONLY);
   ValidityRange vr(run, lb);
   pss.reset();
 
   // read the prescale key
   {
      IFolderPtr hltpskFolder = TrigConfCoolFolderSpec::getHltPrescaleKeyFolder(m_dbPtr);
      IObjectIteratorPtr objects = hltpskFolder->browseObjects( vr.since(), vr.since()+1, 0 );
      objects->goToNext();
      const IObject& obj = objects->currentRef();
      const IRecord & payload = obj.payload();
      unsigned int hltpsk = readHltPrescaleKey( payload.attributeList() );
      pss.setId(hltpsk);
   }
 
   // read the prescale set
   {
      float ps, pt, rrps;
      HLTLevel level;
      cool::IFolderPtr hltpssFolder = TrigConfCoolFolderSpec::getHltPrescalesFolder(m_dbPtr);
      cool::IObjectIteratorPtr objects = hltpssFolder->browseObjects( vr.since(), vr.since()+1, cool::ChannelSelection());
      bool iovset=false;
      while(objects->goToNext()) {
         const cool::IObject& obj = objects->currentRef();
         if(!iovset) {
            pss.setIOV(obj.since(), obj.until()); // assume the IOV of the first channel is like all the others
            iovset=true;
         }
         const ChannelId& ch = obj.channelId();
         const IRecord& payload = obj.payload();
         readHltPrescale( payload.attributeList(), ps, pt, rrps);
     unsigned int counter = ch/2;
 
     if (ch >=20000 ) {
       level=HLT;
       counter = ch - 20000;
     } else
       level = (ch%2==0)?L2:EF;
         
         pss.thePrescale( counter, level )
            .setPrescale(ps)
            .setPassThrough(pt)
            .setRerunPrescale("",rrps);
      }
   }
}

readL1BunchGroupLBPayload()

void TrigConfCoolWriter::readL1BunchGroupLBPayload	(	unsigned int	runNumber,
		unsigned int	lumiblockNumber,
		int &	bgKey,
		TrigConf::BunchGroupSet &	bgs )

Reading lb-wise bunch group configuration information from COOL database.

Parameters

runNumber	run number
lumiblockNumber	lb number
bgKey	HLT bunch group set configuration key
bgs	the bunchgroup set

Definition at line 1576 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_ONLY);
   ValidityRange vr(run,lb);
   vr.until() = vr.since(); // single LB
 
   // read the bunch group key
   IFolderPtr lvl1BGKeyFolder = TrigConfCoolFolderSpec::getLvl1BGKeyFolder(m_dbPtr);
   IObjectIteratorPtr objects = lvl1BGKeyFolder->browseObjects( vr.since(), vr.until(), 0 );
   objects->goToNext();
   const IObject& obj = objects->currentRef();
   const IRecord & payload1 = obj.payload();
   bgKey = readLvl1BGKey( payload1.attributeList() );
 
   // read the bunch group content
   IFolderPtr lvl1BGContentFolder = TrigConfCoolFolderSpec::getLvl1BGContentFolder(m_dbPtr);
   IObjectIteratorPtr objects2 = lvl1BGContentFolder->browseObjects( vr.since(), vr.until(), 0);
   objects2->goToNext();
   const IObject& obj2 = objects2->currentRef();
   const IRecord & payload2 = obj2.payload();
   vector<BunchGroup> bgV = readLvl1BGContent( payload2.attributeList() );
 
   // read the bunch group names
   pair< vector<string>, map<unsigned int,unsigned char> > bg_pair = readL1BunchGroupRunPayload(run);
   vector<string> names = bg_pair.first;
 
 
   
   uint newBGSSize = bgV.size() <= names.size() ? bgV.size() : names.size();
 
   if(bgV.size() !=  names.size()) {
      cout << "WARNING Bunchgroup content vector is of size " << bgV.size()
           << ", which is different from the size of the names vector: " << names.size()
           << ". Using " << newBGSSize << endl;
 
   }
 
   // create a new bunch group set, set names and bunch groups
   bgs = BunchGroupSet();
   for(unsigned int i=0; i<newBGSSize; i++) {
      string bgname = names[i];
      if(bgname=="") bgname = "NoName";
      bgV[i].setName(bgname);
      bgV[i].setInternalNumber(i);
      bgs.addBunchGroup(bgV[i]);
   }
   bgs.setId(bgKey);
}

readL1BunchGroupRunPayload()

pair< vector< string >, map< unsigned int, unsigned char > > TrigConf::TrigConfCoolWriter::readL1BunchGroupRunPayload

(

unsigned int

runNumber

)

Reading bunch group configuration information from COOL database.

Parameters

runNumber	run number
lumiblockNumber	lb number
bgKey	HLT bunch group set configuration key
bgs	the bunchgroup set

Definition at line 1554 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_ONLY);
   ValidityRange vr(run);
   IFolderPtr folder = TrigConfCoolFolderSpec::getLvl1BGDescFolder(m_dbPtr);
   IObjectIteratorPtr objects = folder->browseObjects( vr.since(), vr.until()-1, 0 );
   objects->goToNext();
   const IObject& obj = objects->currentRef();
   const IRecord & payload = obj.payload();
   return readLvl1BGDesc( payload.attributeList() );
}

readL1InputMapPayload()

void TrigConfCoolWriter::readL1InputMapPayload	(	unsigned int	runNumber,
		std::vector< TrigConf::PIT * > &	pits,
		std::vector< TrigConf::TIP * > &	tips )

Read run-wise PIT configuration from COOL database.

Parameters

runNumber	run number
pits	Vector of PIT object to be filled

Definition at line 1316 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_ONLY);
   ValidityRange vr(run, 1);
   IObjectIteratorPtr objects;
   IFolderPtr folder = TrigConfCoolFolderSpec::getLvl1InputMapFolder(m_dbPtr);
   vector<bool> foundTip(512,false);
   for(ChannelId channel = 0; channel < 512; ++channel) {
      objects = folder->browseObjects( vr.since(), vr.until()-1, channel );
      if(objects->size()==0) continue;
      while ( objects->goToNext() ) {
         const IObject& obj = objects->currentRef();
         const IRecord & payload = obj.payload();
         PIT* pit = readLvl1InputMap( payload.attributeList() );
         TIP* tip = readLvl1TIPMap( payload.attributeList() );
         uint16_t tipNumber = obj.channelId();
         if(tipNumber > 511) {
            m_ostream << "TIP number " << tipNumber << " out of bounds!" << endl;
            throw runtime_error("TIP number ouf ot bounds!");
         } else {
            if(foundTip[tipNumber]) {
               stringstream str;
               str << "TIP '" << tipNumber << "' had already been read!";
               throw runtime_error(str.str());
            }
            foundTip[tipNumber] = true;
            pit->setPitNumber(tipNumber);
            tip->setTipNumber(tipNumber);
            tip->setClock(tipNumber%2);
            pits.push_back(pit);
            tips.push_back(tip);
         }
      }     
   }
}

readL1ItemDef()

void TrigConfCoolWriter::readL1ItemDef	(	unsigned int	runNumber,
		const std::vector< TrigConf::TriggerItem * > &	items,
		const std::vector< TrigConf::TriggerThreshold * > &	thrs )

Read run-wise L1 item defintions (conditions) from COOL database.

Parameters

runNumber	run number
items	Vector of Item object to be updated
thrs	Vector of Thresholds from which some are added to the item

Definition at line 1449 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_ONLY);
   ValidityRange vr(run, 1);
 
   IFolderPtr L1ItemDefFolder = TrigConfCoolFolderSpec::getLvl1ItemDefFolder(m_dbPtr);
   for(TriggerItem* item: items) {
      ChannelId itemChannel = item->ctpId();
      IObjectIteratorPtr objects = L1ItemDefFolder->browseObjects( vr.since(), vr.until()-1, itemChannel );
      while ( objects->goToNext() ) {
         const IObject& obj = objects->currentRef();
         const IRecord & payload = obj.payload();
         addThresholdsToTriggerItem( payload.attributeList(), item, thrs);
      }
   }
}

readL1Items()

void TrigConfCoolWriter::readL1Items	(	unsigned int	runNumber,
		std::vector< TrigConf::TriggerItem * > &	items )

Read run-wise L1 item vector from COOL database.

Parameters

runNumber	run number
items	Vector of Item object to be filled

Definition at line 1395 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_ONLY);
   ValidityRange vr(run, 1);
 
   IObjectIteratorPtr objects;
   IFolderPtr folder = TrigConfCoolFolderSpec::getLvl1MenuFolder(m_dbPtr);
   vector<bool> foundItem(512,false);
 
   //for(ChannelId channel = 0; channel < 512; ++channel) {
   objects = folder->browseObjects( vr.since(), vr.until()-1,cool::ChannelSelection());
   //if(objects->size()==0) continue;
   while ( objects->goToNext() ) {
      const cool::IObject& obj = objects->currentRef();
      const cool::IRecord & payload = obj.payload();
      TriggerItem* item = createLvl1TriggerItem( payload.attributeList() );
      uint32_t ctpId = obj.channelId();
      if(ctpId > 511) {
         m_ostream << "Item ctpid " << ctpId << " out of bounds!" << endl;
         throw runtime_error("Item ctpid ouf ot bounds!");
      } else {
         if(foundItem[ctpId]) {
            stringstream str;
            str << "Item '" << ctpId << "' had already been read!";
            throw runtime_error(str.str());
         }
         foundItem[ctpId] = true;
         item->setCtpId(ctpId);
         items.push_back(item);
      }
   }
   //   }
 
}

readL1Menu()

void TrigConfCoolWriter::readL1Menu	(	unsigned int	runNumber,
		CTPConfig &	ctpc )

Read L1 menu from COOL database.

Parameters

runNumber

run number

Returns

L1 Menu pointer

a unpleasant hack so we can figure out if this Run1 (CTPVersion 3) or Run2 (CTPVersion 4)

we use the fact that in Run2 the cable names were different

Definition at line 1470 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_ONLY);
 
   Menu & menu = ctpc.menu();
 
   // thresholds
   vector<TriggerThreshold*> thrs;
   readL1Thresholds(run, thrs);

   bool isRun2 = false;
   for(TriggerThreshold* thr : thrs) {
      if( thr->cableName()=="EM1" || thr->cableName()=="EM2" || 
          thr->cableName()=="JET1" || thr->cableName()=="JET2" || 
          thr->cableName()=="TOPO1" || thr->cableName()=="TOPO2" || 
          thr->cableName()=="TAU1" || thr->cableName()=="TAU2") {
         isRun2 = true;
         break;
      }
   }
   ctpc.setCTPVersion(isRun2 ? 4 : 3);
   ctpc.setL1Version(isRun2 ? 1 : 0);
   L1DataDef::setMaxThresholdsFromL1Version( ctpc.l1Version() );
   cout << "TrigConfCoolWriter::readL1Menu for run " << run << ". Determined format " << (isRun2 ? "Run 2" : "Run 1") << endl;
 
   // items
   vector<TriggerItem*> items;
   readL1Items(run, items);
   for(TriggerItem* item: items)
      menu.addTriggerItem(item);
 
 
   readL1ItemDef(run, items, thrs);
 
   CaloInfo ci;
 
   for(TriggerThreshold* thr: thrs) {
 
      if ( thr->name()=="JetWeights" ) {
         if(!isRun2) {
            for ( const string& weights : split( thr->cableName(),",")  )
               ci.addJetWeight( std::stoi(weights) );
         }
      }
      else if ( thr->name()=="METSigParams" ) {
         vector<string> metvals = split( thr->cableName(),",");
         int XSSigmaScale  = std::stoi(metvals[0]);
         int XSSigmaOffset = std::stoi(metvals[1]);
         int XEmin         = std::stoi(metvals[2]);
         int XEmax         = std::stoi(metvals[3]);
         int TESqrtMin     = std::stoi(metvals[4]);
         int TESqrtMax     = std::stoi(metvals[5]);
         ci.metSigParam().setValues( XSSigmaScale, XSSigmaOffset,
                                     XEmin, XEmax, TESqrtMin, TESqrtMax);
      }
      else {
         // trigger thresholds sorted by type
         menu.thresholdConfig().addTriggerThreshold(thr);
      }
   }
   menu.setCaloInfo(ci);
 
   // PITs (run1), TIPs (run2)
   vector<PIT*> pits;
   vector<TIP*> tips;
   readL1InputMapPayload(run, pits, tips);
   for ( PIT* pit : pits) {
      if(pit->ctpinSlot()==10) continue;
      menu.addPit(pit);
   }
   for ( TIP* tip : tips) {
      //       cout << tip->tipNumber() << "  :  thr = " << tip->thresholdName() << ", slot = " << tip->slot() << ", conn = " << tip->connector() << ", thrBit = "
      //            << tip->thresholdBit() << ", cableBit = " << tip->cableBit() << endl;
      menu.addTip(tip);
   }
}

readL1MonMapPayload()

void TrigConfCoolWriter::readL1MonMapPayload	(	unsigned int	runNumber,
		std::vector< TrigConf::ThresholdMonitor * > &	mons )

Read run-wise LVL1 monitoring configuration from COOL database.

Parameters

runNumber	run number
mons	Vector of mon counter objects to be filled

Definition at line 1355 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_ONLY);
   ValidityRange vr(run, 1);
 
   IObjectIteratorPtr objects;
   IFolderPtr folder = TrigConfCoolFolderSpec::getLvl1MonMapFolder(m_dbPtr);
   vector<bool> foundCounter(768,false);
 
   for(ChannelId channel = 0; channel < 768; ++channel) {
 
      objects = folder->browseObjects( vr.since(), vr.until()-1, channel );
      if(objects->size()==0) continue;
      while ( objects->goToNext() ) {
         const IObject& obj = objects->currentRef();
         const IRecord & payload = obj.payload();
         vector<ThresholdMonitor*> counters = readLvl1MonMap( payload );
         int counterNumber = obj.channelId();
         if(counterNumber > 768) {
            m_ostream << "Monitoring counter number " << counterNumber << " out of bounds!" << endl;
            throw runtime_error("Monitoring counter ouf of bounds!");
         } else {
            if(foundCounter[counterNumber]) {
               stringstream str;
               str << "MonCounter '" << counterNumber << "' had already been read!";
               throw runtime_error(str.str());
            }
            foundCounter[counterNumber] = true;
            for(size_t i = 0 ; i < counters.size(); ++i) {
               counters[i]->setInternalCounter(counterNumber);
               mons.push_back( counters[i] );
            }
         }
      }     
      ++channel;
   }
}

readL1Payload()

void TrigConfCoolWriter::readL1Payload	(	unsigned int	run,
		CTPConfig &	ctpc )

Setting the ctpVersion based on the run number does not work for MC

Definition at line 1303 of file TrigConfCoolWriter.cxx.

{

 
   readL1Menu( run, ctpc );
}

readL1PrescalePayload()

void TrigConfCoolWriter::readL1PrescalePayload	(	unsigned int	runNumber,
		unsigned int	lumiblockNumber,
		unsigned int &	lvl1PrescaleKey,
		TrigConf::PrescaleSet &	prescale )

Reading luminosityblock-wise configuration information the COOL database.

Parameters

runNumber	run number
lumiblockNumber	luminosity block number
lvl1PrescaleKey	L1 prescale configuration key
prescale	L1 prescale configuration object

Definition at line 1636 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_ONLY);
   ValidityRange vr(run,lb);
   vr.until() = vr.since()+1; // single LB
 
   IFolderPtr lvl1CkFolder = TrigConfCoolFolderSpec::getLvl1ConfKeyFolder(m_dbPtr);
   IObjectIteratorPtr objects = lvl1CkFolder->browseObjects( vr.since(), vr.since()+1, 0 );
   objects->goToNext();
   const IObject& obj = objects->currentRef();
   const IRecord & payload = obj.payload();
   readLvl1ConfigKey( payload.attributeList(), lvl1PrescaleKey );
 
 
   cool::IFolderPtr lvl1PsFolder = TrigConfCoolFolderSpec::getLvl1PrescalesFolder(m_dbPtr);
 
   // resize the vector to the correct size
   size_t nPrescales = lvl1PsFolder->listChannels().size();
   bool isRun2 = ( nPrescales == 512 );
   prescale.resize( nPrescales );
 
   for(cool::ChannelId channel = 0; channel < nPrescales; channel++) {
 
      objects = lvl1PsFolder->browseObjects( vr.since(), vr.until(), channel );
 
      if(objects->size()!=1) { 
         throw std::runtime_error("Lvl1 prescale access error: found empty prescale channel ");
      }
 
      objects->goToNext();
      const IObject& obj = objects->currentRef();
      const IRecord & payload = obj.payload();
      int64_t prescaleVal=0;
      readLvl1Prescale( payload.attributeList(), prescaleVal );
      if( isRun2 ) {
         prescale.setCut( channel, prescaleVal );
      } else {
         prescale.setPrescale( channel, (float)prescaleVal );
      }
   }
   prescale.setId( lvl1PrescaleKey );
}

readL1Thresholds()

void TrigConfCoolWriter::readL1Thresholds	(	unsigned int	runNumber,
		std::vector< TrigConf::TriggerThreshold * > &	thrs )

Read run-wise L1 threshold vector from COOL database.

Parameters

runNumber	run number
items	Vector of Item object to be filled

Definition at line 1433 of file TrigConfCoolWriter.cxx.

                                                                      {
   AutoDBOpen db(this, READ_ONLY);
   ValidityRange vr(run, 1);
   thrs.clear();
   IFolderPtr L1thrFolder = TrigConfCoolFolderSpec::getLvl1ThresholdFolder(m_dbPtr);
   IObjectIteratorPtr objects = L1thrFolder->browseObjects( vr.since(), vr.until()-1, cool::ChannelSelection() );
   while ( objects->goToNext() ) {
      const IObject& obj = objects->currentRef();
      const IRecord & payload = obj.payload();
      thrs.push_back( createLvl1Threshold( payload.attributeList() ) );
   }
}

readRunPayload()

void TrigConfCoolWriter::readRunPayload	(	unsigned int	runNumber,
		TrigConf::HLTFrame &	hltFrame,
		unsigned int &	masterConfigKey,
		unsigned int &	hltPrescaleKey,
		std::string &	configSource )

Reading run-wise configuration information from COOL database.

Parameters

runNumber	run number
hltFrame	HLT menu configuration object
masterConfigKey	configuration super master key
hltPrescaleKey	HLT prescale configuration key
configSource	configuration source (DB connection string or XML file name(s))

Definition at line 1290 of file TrigConfCoolWriter.cxx.

{
   readHLTPayload( run, hltFrame);
   masterConfigKey = hltFrame.smk();
   configSource = hltFrame.configSource();
}

recreateDb()

cool::IDatabasePtr TrigConf::TrigConfCoolWriter::recreateDb ( )

private

create a new COOL database with prior deletion of the old one

recreateSchema()

void TrigConf::TrigConfCoolWriter::recreateSchema

(

int

schemaVersion = 0

)

Create a new schema in the COOL database with prior deletion of the old one.

Definition at line 232 of file TrigConfCoolWriter.cxx.

{}

setVerbosityLevel()

void TrigConf::TrigConfCoolWriter::setVerbosityLevel ( unsigned int level )

inline

Definition at line 380 of file TrigConfCoolWriter.h.

{ m_verbosityLevel = level; }

shouldFolderBeUpdated()

bool TrigConf::TrigConfCoolWriter::shouldFolderBeUpdated ( const std::string & foldername )

inlineprivate

check if foldername is in list of writeable folders

Definition at line 432 of file TrigConfCoolWriter.h.

                                                               {
         if( m_writeFolderList.size()==0 ) return true; // nothing specified --> write everything (default)
         return std::count(m_writeFolderList.begin(),m_writeFolderList.end(),foldername)>0;
      }

verbosityLevel()

unsigned int TrigConf::TrigConfCoolWriter::verbosityLevel ( ) const

inline

Definition at line 381 of file TrigConfCoolWriter.h.

{ return m_verbosityLevel; }

writeHLTPayload()

void TrigConf::TrigConfCoolWriter::writeHLTPayload	(	ValidityRange	vr,
		const HLTFrame &	hltFrame,
		const std::string &	configSource )

Definition at line 323 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_WRITE);
   TrigConfCoolFolderSpec::createFolderStructure(m_dbPtr); // just in case
 
   // writing configuration keys
   if( shouldFolderBeUpdated("/TRIGGER/HLT/HltConfigKeys") ) {
      rangeInfo("HLT configuration keys", vr.since(), vr.until());
      try {
         IFolderPtr confkeyFolder = TrigConfCoolFolderSpec::getHltConfKeyFolder(m_dbPtr);
         Record     payload = createHltConfigKeysPayload(confkeyFolder, hltFrame.smk(), 0, configSource);
         confkeyFolder->storeObject(vr.since(), vr.until(), payload, 0);
      }
      catch(exception & e) {
         m_ostream << "<writeHLTPayload> caught and re-throw exception: " << e.what() << endl
                   << "WARNING: Failed to write configuration keys to COOL" << endl;
         throw;
      }
   }
 
   if(!hltFrame.getPrescaleSetCollection().sets().empty()) {
      // we only support one prescale set at a time here
      const HLTPrescaleSet& pss = *hltFrame.getPrescaleSetCollection().sets().front().pss;
      writeHltPrescalePayload(vr.since(), vr.until(), pss);
   }
 
   if( shouldFolderBeUpdated("/TRIGGER/HLT/Menu") ||
       shouldFolderBeUpdated("/TRIGGER/HLT/Groups") ) {
      if( hltFrame.getHLTChainList().size() > 0 ) {
         
         rangeInfo("HLT menu", vr.since(), vr.until());
 
         // this call is needed to set the level of each sequence
         TrigConf::HLTTEUtils::allTEsProduced( hltFrame );
 
         // writing the chains of the HLT menu
         try {
                        
            ChannelId menuChannel(0);
            IFolderPtr hltMenuFolder = TrigConfCoolFolderSpec::getHltMenuFolder(m_dbPtr);
            IFolderPtr hltGroupFolder = TrigConfCoolFolderSpec::getHltChainGroupFolder(m_dbPtr);
            // use buffer to speed up COOL writing
            hltMenuFolder->setupStorageBuffer(); 
            hltGroupFolder->setupStorageBuffer(); 
 
            for ( const HLTChain* chain : hltFrame.getHLTChainList() ) {
               menuChannel++;
               string concise = HLTTEUtils::ChainCondenseDisplay( *chain, hltFrame);
               Record payload = createHltMenuPayload( hltMenuFolder, *chain, concise );
               hltMenuFolder->storeObject(vr.since(), vr.until(), payload, menuChannel);
 
               Record payloadGroups = TrigConfCoolHLTPayloadConverters::createHltChainGroupPayload(hltGroupFolder, *chain );
               hltGroupFolder->storeObject(vr.since(), vr.until(), payloadGroups, menuChannel);
               m_ostream << "Writing (to buffer) HLT chain " << chain->chain_name()
                         << "(id " << chain->chain_counter()
             << " level "<< chain->level()
                         << ") to COOL channel " << menuChannel
                         << " [belongs to groups " << payloadGroups["Groups"].data<cool::String4k>() << "]" << endl;
            }
            if( shouldFolderBeUpdated("/TRIGGER/HLT/Menu") ) {
               m_ostream << "Flushing HLT menu buffer to /TRIGGER/HLT/Menu" << endl; 
               try {
                  hltMenuFolder->flushStorageBuffer();
               } 
               catch ( cool::Exception & e) {
                  m_ostream << "WARNING: Flushing buffer to DB failed: " << e.what() << endl
                            << "warning will be ignored, job will continue" << endl;
               }
            }
            if( shouldFolderBeUpdated("/TRIGGER/HLT/Groups") ) {
               m_ostream << "Flushing HLT group buffer to /TRIGGER/HLT/Groups" << endl;
               try {
                  hltGroupFolder->flushStorageBuffer();
               }
               catch ( cool::Exception & e) {
                  m_ostream << "WARNING: Flushing buffer to DB failed: " << e.what() << endl
                            << "warning will be ignored, job will continue" << endl;
               }
            }
         }
         catch( cool::Exception & e) {
            m_ostream << "Caught cool::Exception: " << e.what() << endl;
            m_ostream << "Failed to write HLT menu to COOL" << endl;    
            throw;
         }
         catch(std::exception & e) {
            m_ostream << "<writeHLTPayload> Caught std::exception: " << e.what() << endl;
            throw;
         }
      } else {
         m_ostream << "List of HLT Chains is empty, nothing is written to COOL" << endl;
      }
   }
}

writeHltPrescalePayload() [1/3]

void TrigConfCoolWriter::writeHltPrescalePayload	(	const RunRangeVec &	runRanges,
		const TrigConf::HLTPrescaleSet &	pss )

Definition at line 1024 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_WRITE);
   TrigConfCoolFolderSpec::createFolderStructure(m_dbPtr);
   for ( RunRange rr : runRanges) {
      ValidityRange vr(rr);
      writeHltPrescalePayload( vr.since(), vr.until(), pss);
   }
}

writeHltPrescalePayload() [2/3]

void TrigConf::TrigConfCoolWriter::writeHltPrescalePayload	(	cool::ValidityKey	since,
		cool::ValidityKey	until,
		const TrigConf::HLTPrescaleSet &	pss )

writeHltPrescalePayload() [3/3]

void TrigConfCoolWriter::writeHltPrescalePayload	(	unsigned int	runNumber,
		unsigned int	lumiblockNumber,
		const TrigConf::HLTPrescaleSet &	pss )

Writing luminosityblock-wise configuration information the COOL database.

Parameters

runNumber	run number
lumiblockNumber	luminosity block number
hltPrescaleKey	HLT prescale configuration key
prescale	HLT prescale configuration object

Definition at line 1037 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_WRITE);
   TrigConfCoolFolderSpec::createFolderStructure(m_dbPtr); 
   ValidityRange vr(run, lb);
   writeHltPrescalePayload( vr.since(), vr.until(), pss);
}

writeL1BunchGroupLBPayload() [1/2]

void TrigConf::TrigConfCoolWriter::writeL1BunchGroupLBPayload	(	const RunRangeVec &	runRanges,
		unsigned int	bgKey,
		const BunchGroupSet &	bgs )

Writing LB-wise L1 bunch group definition to the COOL database.

Parameters

runNumber	run number
bgs	BunchGroup set

Definition at line 976 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_WRITE);
   for ( RunRange rr : runRanges) {
      ValidityRange vr(rr);
      writeL1BunchGroupLBPayload( rr, bgKey, bgs);
   }
}

writeL1BunchGroupLBPayload() [2/2]

void TrigConf::TrigConfCoolWriter::writeL1BunchGroupLBPayload	(	ValidityRange	vr,
		unsigned int	bgKey,
		const BunchGroupSet &	bgs )

Definition at line 988 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_WRITE);
   TrigConfCoolFolderSpec::createFolderStructure(m_dbPtr);
   try {
      if( shouldFolderBeUpdated("/TRIGGER/LVL1/BunchGroupKey") ) {
         rangeInfo("LVL1 bunchgroup key", vr.since(), vr.until());
         IFolderPtr lvl1BGKFolder = TrigConfCoolFolderSpec::getLvl1BGKeyFolder(m_dbPtr);
         Record payload = createLvl1BGKeyPayload(lvl1BGKFolder, bgKey);
         m_ostream << "Store LVL1 BG key to /TRIGGER/LVL1/BunchGroupKey" << endl;
         lvl1BGKFolder->storeObject(vr.since(), vr.until(), payload, 0);
      }
 
      if( shouldFolderBeUpdated("/TRIGGER/LVL1/BunchGroupContent") ) {
         rangeInfo("LVL1 bunchgroups", vr.since(), vr.until());
         IFolderPtr lvl1BGContentFolder = TrigConfCoolFolderSpec::getLvl1BGContentFolder(m_dbPtr);
         Record payload = createLvl1BGContentPayload(lvl1BGContentFolder, bgs);
         m_ostream << "Store LVL1 BG content to /TRIGGER/LVL1/BunchGroupContent" << endl;
         lvl1BGContentFolder->storeObject(vr.since(), vr.until(), payload, 0);
      }
   }
   catch(exception & e) {
      m_ostream << "<writeLVL1BGPayload> caugh and re-throw exception: " << e.what() << endl;
      throw;
   }
}

writeL1BunchGroupRunPayload() [1/2]

void TrigConf::TrigConfCoolWriter::writeL1BunchGroupRunPayload	(	const RunRangeVec &	runRanges,
		const TrigConf::Menu &	lvl1Menu,
		const TrigConf::BunchGroupSet &	bgs )

Definition at line 964 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_WRITE);
   TrigConfCoolFolderSpec::createFolderStructure(m_dbPtr);
   for ( RunRange rr : runRanges)
      writeL1BunchGroupRunPayload( rr, lvl1Menu, bgs);
}

writeL1BunchGroupRunPayload() [2/2]

void TrigConf::TrigConfCoolWriter::writeL1BunchGroupRunPayload	(	ValidityRange	vr,
		const Menu &	lvl1Menu,
		const BunchGroupSet &	bgs )

Writing run-wise L1 bunch group names and item to bunch group mapping to COOL.

Parameters

runNumber	run number
lvl1Menu	L1 Menu
bgs	BunchGroup set

Definition at line 942 of file TrigConfCoolWriter.cxx.

{
   if( !shouldFolderBeUpdated("/TRIGGER/LVL1/BunchGroupDescription") ) return;
   AutoDBOpen db(this, READ_WRITE);
   TrigConfCoolFolderSpec::createFolderStructure(m_dbPtr);
   rangeInfo("LVL1 bunch group descriptions", vr.since(), vr.until());
   try {
      IFolderPtr bgDescFolder = TrigConfCoolFolderSpec::getLvl1BGDescFolder(m_dbPtr);
      Record payload = createLvl1BGDescPayload(bgDescFolder, bgs,lvl1Menu);
      m_ostream << "Store LVL1 BG description buffer to /TRIGGER/LVL1/BunchGroupDescription" << endl;
      bgDescFolder->storeObject(vr.since(), vr.until(), payload, 0);
   }
   catch(exception & e) {
      m_ostream << "<writeL1BunchGroupRunPayload> caught and re-throw exception: " << e.what() << endl;
      throw;
   }
}

writeL1CTPCoreInputMapping()

void TrigConf::TrigConfCoolWriter::writeL1CTPCoreInputMapping	(	ValidityRange	vr,
		const Menu &	lvl1Menu )

Definition at line 891 of file TrigConfCoolWriter.cxx.

{
   if( ! shouldFolderBeUpdated("/TRIGGER/LVL1/CTPCoreInputMapping") )
      return;
 
   AutoDBOpen db(this, READ_WRITE);
 
   // now write PIT mapping
   try {
 
      cool::IFolderPtr tipFolder = TrigConfCoolFolderSpec::getLvl1InputMapFolder(m_dbPtr);
      tipFolder->setupStorageBuffer();
 
      for ( const TIP * tip : lvl1Menu.tipVector() ) {
 
         cool::ChannelId tipNum = static_cast<cool::ChannelId>(tip->tipNumber());
 
         stringstream tipName;
         tipName << "name:" << tip->thresholdName();
         tipName << "|thresh bit:" << tip->thresholdBit();
         tipName << "|pos:" << tip->thresholdMapping();
         tipName << "|active:" << tip->thresholdActive();
         tipName << "|ctpin slot:" << tip->slot();
         tipName << "|con:" << tip->connector();
         tipName << "|cable bit:" << tip->cableBit();
         m_ostream << "Write TIP / channel " << tipNum << " : " << tipName.str() << endl;
 
         Record payload = TrigConfCoolL1PayloadConverters::createLvl1InputMapPayload( tipFolder, *tip );
         tipFolder->storeObject(vr.since(), vr.until(), payload, tipNum);
      }
      m_ostream << "Flushing LVL1 CTPInputMap buffer to /TRIGGER/LVL1/CTPCoreInputMapping" << endl;
      tipFolder->flushStorageBuffer();
   } catch( cool::Exception & e) {
      m_ostream << "Caught cool::Exception: " << e.what() << endl;
      m_ostream << "Failed to write LVL1 TIP mapping to COOL" << endl;
      throw;
   } catch( exception & e) {
      m_ostream << "<writeLVL1RunPayload> Caught std::exception: " << e.what() << endl;
      throw;
   }
}

writeL1MenuPayload() [1/2]

void TrigConf::TrigConfCoolWriter::writeL1MenuPayload	(	const RunRangeVec &	runRanges,
		const TrigConf::Menu &	lvl1Menu )

Definition at line 876 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_WRITE);
   for ( RunRange rr : runRanges)
      writeL1MenuPayload( rr, lvl1Menu );
}

writeL1MenuPayload() [2/2]

void TrigConf::TrigConfCoolWriter::writeL1MenuPayload	(	ValidityRange	vr,
		const TrigConf::Menu &	lvl1Menu )

Writing L1 run-wise configuration information to the COOL database.

Parameters

runNumber	run number
lvl1Menu	L1 Menu

Definition at line 743 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_WRITE);
   TrigConfCoolFolderSpec::createFolderStructure(m_dbPtr); // just in case
 
   // writing the Lvl1 menu
   try {
      if( shouldFolderBeUpdated("/TRIGGER/LVL1/Thresholds") &&
          lvl1Menu.thresholdConfig().thresholdVector().size()>0 ) { // if there are no thresholds we don't want to write anything (METsig, JETWeights)
         // get the folders for the menu, itemDef, and thresholds
         cool::IFolderPtr lvl1ThresholdFolder = TrigConfCoolFolderSpec::getLvl1ThresholdFolder(m_dbPtr);
         
         rangeInfo("LVL1 thresholds", vr.since(), vr.until());
         // first, parse the threshold list and write to threshold folder
         const std::vector<TrigConf::TriggerThreshold*> & lvl1Thrs = lvl1Menu.thresholdConfig().thresholdVector();
         // use buffer to speed up COOL writing
 
         lvl1ThresholdFolder->setupStorageBuffer();
 
         // go through the thresholds, channels assigned in the order (0..#thr-1)
         cool::ChannelId thrChannel = 0;
         for (TrigConf::TriggerThreshold* thr : lvl1Thrs) {
            Record payloadThr = TrigConfCoolL1PayloadConverters::createLvl1ThresholdPayload( lvl1ThresholdFolder, *thr );
            m_ostream << "Writing (to buffer) LVL1 threshold " << thr->name() 
                      << " (version " << thr->version() << ") to channel "
                      << thrChannel << endl;
            lvl1ThresholdFolder->storeObject(vr.since(), vr.until(), payloadThr, thrChannel++);
         }
 
 
         // TODO
         if( lvl1Menu.thresholdConfig().l1Version() == 0 ) {
            m_ostream << "Writing (to buffer) LVL1 threshold 'JetWeights':";
            const std::vector<int>& jetweights = lvl1Menu.caloInfo().jetWeights();
            std::copy(jetweights.begin(), jetweights.end(), std::ostream_iterator<int>(m_ostream, ", "));
            m_ostream << endl;
            Record payloadJW = TrigConfCoolL1PayloadConverters::createLvl1JetWeightPayload( lvl1ThresholdFolder, lvl1Menu.caloInfo().jetWeights() );
            lvl1ThresholdFolder->storeObject(vr.since(), vr.until(), payloadJW, thrChannel++);
         }
 
         m_ostream << "Writing (to buffer) LVL1 threshold 'MET Significance parameters':";
         lvl1Menu.caloInfo().metSigParam().print();
         cool::Record payloadMETSigParams = TrigConfCoolL1PayloadConverters::createLvl1METSigPayload( lvl1ThresholdFolder, lvl1Menu.caloInfo().metSigParam() );
         lvl1ThresholdFolder->storeObject(vr.since(), vr.until(), payloadMETSigParams, thrChannel++);
 
         // write
         m_ostream << "Flushing LVL1 thresholds buffer to /TRIGGER/LVL1/Thresholds" << endl;
         try {
            lvl1ThresholdFolder->flushStorageBuffer();
         }
         catch ( cool::Exception & e) {
            m_ostream << "WARNING: Flushing buffer to DB failed: " << e.what() << endl
                      << "warning will be ignored, job will continue" << endl;
         }
      }
   } catch( cool::Exception & e) {
      m_ostream << "Caught cool::Exception: " << e.what() << endl;
      m_ostream << "Failed to write LVL1 menu to COOL" << endl;    
      throw;
   } catch(std::exception & e) {
      m_ostream << "<writeLVL1RunPayload> Caught std::exception: " << e.what() << endl;
      throw;
   }
 
 
   try {
 
      // second, parse the items and write to menu and itemDef folders
      if( shouldFolderBeUpdated("/TRIGGER/LVL1/Menu") ||
          shouldFolderBeUpdated("/TRIGGER/LVL1/ItemDef") ) {
         
         rangeInfo("LVL1 menu", vr.since(), vr.until());
 
         cool::IFolderPtr lvl1MenuFolder = TrigConfCoolFolderSpec::getLvl1MenuFolder(m_dbPtr);
         cool::IFolderPtr lvl1ItemDefFolder = TrigConfCoolFolderSpec::getLvl1ItemDefFolder(m_dbPtr);
 
         // use buffer to speed up COOL writing
         lvl1MenuFolder->setupStorageBuffer();
         lvl1ItemDefFolder->setupStorageBuffer();
         // go through the items
         for ( TriggerItem* item : lvl1Menu.items()) {
            cool::Record    payloadMenu = TrigConfCoolL1PayloadConverters::createLvl1MenuPayload( lvl1MenuFolder, *item );
            cool::Record    payloadItemDef  = TrigConfCoolL1PayloadConverters::createLvl1ItemDefPayload( lvl1ItemDefFolder, *item );
            cool::ChannelId menuChannel = static_cast<cool::ChannelId>(item->ctpId()); // int -> uint32
            m_ostream << "Writing (to buffer) LVL1 item " << item->name() 
                      << " (logic " << payloadItemDef["Logic"].data<cool::String255>() 
                      << ": [" << payloadItemDef["ConditionsList"].data<cool::String4k>() << "]) to channel "
                      << menuChannel << endl;
            if( shouldFolderBeUpdated("/TRIGGER/LVL1/Menu") )
               lvl1MenuFolder->storeObject(vr.since(), vr.until(), payloadMenu, menuChannel);
 
            if( shouldFolderBeUpdated("/TRIGGER/LVL1/ItemDef") )
               lvl1ItemDefFolder->storeObject(vr.since(), vr.until(), payloadItemDef, menuChannel);
         }
         // write
         if( shouldFolderBeUpdated("/TRIGGER/LVL1/Menu") ) {
            m_ostream << "Flushing LVL1 menu buffer to /TRIGGER/LVL1/Menu" << endl;
            try {
               lvl1MenuFolder->flushStorageBuffer();
            }
            catch ( cool::Exception & e) {
               m_ostream << "WARNING: Flushing buffer to DB failed: " << e.what() << endl
                         << "warning will be ignored, job will continue" << endl;
            }
         }
         if( shouldFolderBeUpdated("/TRIGGER/LVL1/ItemDef") ) {
            m_ostream << "Flushing LVL1 item buffer to /TRIGGER/LVL1/ItemDef" << endl;
            try {
               lvl1ItemDefFolder->flushStorageBuffer();
            }
            catch ( cool::Exception & e) {
               m_ostream << "WARNING: Flushing buffer to DB failed: " << e.what() << endl
                         << "warning will be ignored, job will continue" << endl;
            }
         }                                       
      }
   } catch( cool::Exception & e) {
      m_ostream << "Caught cool::Exception: " << e.what() << endl;
      m_ostream << "Failed to write LVL1 menu to COOL" << endl;    
      throw;
   } catch(std::exception & e) {
      m_ostream << "<writeLVL1RunPayload> Caught std::exception: " << e.what() << endl;
      throw;
   }
 
   writeL1CTPCoreInputMapping( vr, lvl1Menu );
 
}

writeL1MonPayload() [1/2]

void TrigConf::TrigConfCoolWriter::writeL1MonPayload	(	const RunRangeVec &	runRanges,
		const TrigConf::Menu *	lvl1Menu )

Definition at line 505 of file TrigConfCoolWriter.cxx.

{
   if(lvl1Menu == 0) throw std::runtime_error("L1 trigger menu ptr is NULL");
 
   AutoDBOpen db(this, READ_WRITE);
   // just in case
   TrigConfCoolFolderSpec::createMonFolderStructure(m_dbPtr); 
 
   // loop over the run ranges
   for ( RunRange rr : runRanges) {
  
      ValidityRange vr(rr);
      rangeInfo("LVL1 monitoring", vr.since(), vr.until());
 
      if( shouldFolderBeUpdated("/TRIGGER/LVL1/CTPInMonitoringMapping") ) {
 
         try {
            // maps to store exact description of mon counters; channel id is
            // internal mon counter id. Different  entries in the mon vector
            // belong to the same counter, the strings are concatenated,
            // separated by ':'
            std::map<cool::ChannelId,std::string> monNames;
            std::map<cool::ChannelId,std::string> thrNames;
            std::map<cool::ChannelId,std::string> slots;
            std::map<cool::ChannelId,std::string> cons;
            std::map<cool::ChannelId,std::string> mults;
            std::map<cool::ChannelId,std::string> starts;
            std::map<cool::ChannelId,std::string> ends;
            std::map<cool::ChannelId,std::string> actives;
            // not possible yet           std::map<cool::ChannelId,std::string> counterlogic;
            // the next 2 must be unique
            std::map<cool::ChannelId,std::string> counterType;
            std::map<cool::ChannelId,uint16_t> bgId;
            const std::vector<TrigConf::ThresholdMonitor*>& monCounter = lvl1Menu->moncountVector();
            std::vector<TrigConf::ThresholdMonitor*>::const_iterator mc = monCounter.begin();
            for(;mc != monCounter.end(); ++mc) {
               cool::ChannelId index = static_cast<cool::ChannelId>((*mc)->internalCounter());
               // the CTPMON goes into the same table, the configuration 
               // of the 160 counters is written with internal counter 
               // as MONCOUNTER + 768, i.e. is added at the end 
               if((*mc)->counterType().find("CTPMON") != std::string::npos) { 
                  index += 768; 
               } 
 
               //prepare strings
               std::stringstream strSlot; strSlot << (*mc)->ctpinSlot();
               std::stringstream strCon; strCon << (*mc)->ctpinConnector();
               std::stringstream strMult; strMult << (*mc)->multiplicity();
               std::stringstream strStart; strStart << (*mc)->thresholdStartBit();
               std::stringstream strEnd; strEnd << (*mc)->thresholdEndBit();
               std::string active;
               if((*mc)->thresholdActive()) active = "ENABLED";
               else active = "DISABLED";
 
 
               int flag=0;//0: not write, 1: write new entry, 2: concatenate
               if( monNames.find(index) == monNames.end() ){
                  //no entries for this counter
                  flag=1;
               }else{
                  flag=2;
 
                  //check if all parameters exist for the index
                  if( thrNames.find(index) == thrNames.end() ){
                     flag=1;
                     m_ostream << "PROBLEM counter " << index << " : no thrNames in previous entries, overwrite all with new one" << endl;
                  }else if( slots.find(index) == slots.end() ){
                     flag=1;
                     m_ostream << "PROBLEM counter " << index << " : no slots in previous entries, overwrite all with new one" << endl;
                  }else if( cons.find(index) == cons.end() ){
                     flag=1;
                     m_ostream << "PROBLEM counter " << index << " : no cons in previous entries, overwrite all with new one" << endl;
                  }else if( mults.find(index) == mults.end() ){
                     flag=1;
                     m_ostream << "PROBLEM counter " << index << " : no mults in previous entries, overwrite all with new one" << endl;
                  }else if( starts.find(index) == starts.end() ){
                     flag=1;
                     m_ostream << "PROBLEM counter " << index << " : no starts in previous entries, overwrite all with new one" << endl;
                  }else if( ends.find(index) == ends.end() ){
                     flag=1;
                     m_ostream << "PROBLEM counter " << index << " : no ends in previous entries, overwrite all with new one" << endl;
                  }else if( actives.find(index) == actives.end() ){
                     flag=1;
                     m_ostream << "PROBLEM counter " << index << " : no actives in previous entries, overwrite all with new one" << endl;
                  }else if( counterType.find(index) == counterType.end() ){
                     flag=1;
                     m_ostream << "PROBLEM counter " << index << " : no counterType in previous entries, overwrite all with new one" << endl;
                  }else if( bgId.find(index) == bgId.end() ){
                     flag=1;
                     m_ostream << "PROBLEM counter " << index << " : no bgId in previous entries, overwrite all with new one" << endl;
                  }else{
 
                     //check if previous entries for same name have same parameters
                     std::vector<std::string> thrNamesCheck = split(thrNames[index],":");
                     std::vector<std::string> slotsCheck = split(slots[index],":");
                     std::vector<std::string> consCheck = split(cons[index],":");
                     std::vector<std::string> multsCheck = split(mults[index],":");
                     std::vector<std::string> startsCheck = split(starts[index],":");
                     std::vector<std::string> endsCheck = split(ends[index],":");
                     std::vector<std::string> activesCheck = split(actives[index],":");
                     if (thrNamesCheck.size() != slotsCheck.size()||
                         thrNamesCheck.size() != consCheck.size()||
                         thrNamesCheck.size() != multsCheck.size()||
                         thrNamesCheck.size() != startsCheck.size()||
                         thrNamesCheck.size() != endsCheck.size()||
                         thrNamesCheck.size() != activesCheck.size()){
                        flag=1;
                        m_ostream << "PROBLEM counter " << index << " : numbers of entries are different, overwrite all with new one" << endl;
                     }else{
                        for (unsigned int i = 0; i < thrNamesCheck.size();i++){
                           if(thrNamesCheck[i]==(*mc)->thresholdName()&&
                              slotsCheck[i]==strSlot.str()&&
                              consCheck[i]==strCon.str()&&
                              multsCheck[i]==strMult.str()&&
                              startsCheck[i]==strStart.str()&&
                              endsCheck[i]==strEnd.str()&&
                              activesCheck[i]==active){
 
                              flag=0;
                              break;
                           }
                        }
                     }
                  }
               }
 
               if(flag==0)continue;
 
 
               if(flag==1){
                  monNames[index]=(*mc)->name();
                  thrNames[index]=(*mc)->thresholdName();
                  slots[index]=strSlot.str();
                  cons[index]=strCon.str();
                  mults[index]=strMult.str();
                  starts[index]=strStart.str();
                  ends[index]=strEnd.str();
                  actives[index]=std::move(active);
                  counterType[index]=(*mc)->counterType();
                  bgId[index]=(*mc)->bunchGroupId();
                  // not possible yet
                  //                  monNames[index]=(*mc)->counterLogic();
               }else if(flag==2){
                  if (monNames[index]!=(*mc)->name()){
                     std::stringstream str;
                     str << "PROBLEM counter " << index;
                     str << " : previous monitor name" << monNames[index];
                     str << ", current monitor name " << (*mc)->name() << endl;
                     m_ostream << str.str() << endl; 
                     // throw std::runtime_error(str.str()); 
                  }
                  if(counterType[index] != (*mc)->counterType()) {
                     std::stringstream str;
                     str << "PROBLEM counter " << index;
                     str << " : previous type " << counterType[index];
                     str << ", current type " << (*mc)->counterType() << endl;
                     m_ostream << str.str() << endl; 
                     // throw std::runtime_error(str.str()); 
                  }
                  if(bgId[index] != (*mc)->bunchGroupId()) {
                     std::stringstream str;
                     str << "PROBLEM counter " << index;
                     str << " : previous bunch-group id " << bgId[index];
                     str << ", current id " << (*mc)->bunchGroupId() << endl;
                     m_ostream << str.str() << endl; 
                     // throw std::runtime_error(str.str());
                  }
                  monNames[index]=(*mc)->name();
                  counterType[index]=(*mc)->counterType();
                  bgId[index]=(*mc)->bunchGroupId();
 
                  thrNames[index]+=":";thrNames[index]+=(*mc)->thresholdName();
                  slots[index]+=":";slots[index]+=strSlot.str();
                  cons[index]+=":";cons[index]+=strCon.str();
                  mults[index]+=":";mults[index]+=strMult.str();
                  starts[index]+=":";starts[index]+=strStart.str();
                  ends[index]+=":";ends[index]+=strEnd.str();
                  actives[index]+=":";actives[index]+=active;
               }else{
                  m_ostream << "PROBLEM counter " << index << " : unknown flag = " << flag << endl;
                  continue;
               } 
            }
 
            cool::ChannelId channel(0);
            cool::IFolderPtr monFolder = TrigConfCoolFolderSpec::getLvl1MonMapFolder(m_dbPtr);
            // use buffer to speed up COOL writing
            monFolder->setupStorageBuffer();
            for(std::map<cool::ChannelId,std::string>::iterator it = thrNames.begin();
                it != thrNames.end();++it) {
               channel = it->first;
               cool::Record payload = 
                  TrigConfCoolL1PayloadConverters::createLvl1MonMapPayload( monFolder,
                                                                            counterType[channel],
                                                                            bgId[channel],
                                                                            it->second,
                                                                            slots[channel],
                                                                            cons[channel],
                                                                            mults[channel],
                                                                            starts[channel],
                                                                            ends[channel],
                                                                            actives[channel],
                                                                            monNames[channel]);
               // add counterlogic above and below when implemented in trigger db
 
               m_ostream << "Write monitoring counter (channel " << channel << ") :: " 
                         << " monname '" << monNames[channel] << "'"
                         << " type '" << counterType[channel] << "'" 
                         << " bgid '" << bgId[channel] << "'" 
                         << " thnames '" << it->second << "'"
                         << " slots '" << slots[channel] << "'" 
                         << " connectors '" << cons[channel] << "'" 
                         << " multiplicities '" << mults[channel] << "'" 
                         << " start bits '" << starts[channel] << "'" 
                         << " end bits '" << ends[channel] << "'" 
                         << " thresholds active '" << actives[channel] << "'" 
                         << endl;
               monFolder->storeObject(vr.since(), vr.until(), payload, channel);
            }
            monFolder->flushStorageBuffer();
         } catch( cool::Exception & e) {
            m_ostream << "Caught cool::Exception: " << e.what() << endl;
            m_ostream << "Failed to write LVL1 monitoring mapping to COOL" << endl;    
            //throw;
         } catch(std::exception & e) {
            m_ostream << "<writeLVL1MonPayload> Caught std::exception: " << e.what() << endl;
            //throw;
         }
      }
   }
}

writeL1MonPayload() [2/2]

void TrigConf::TrigConfCoolWriter::writeL1MonPayload	(	unsigned int	runNumber,
		const TrigConf::Menu *	lvl1Menu )

Writing L1 run-wise monitoring configuration to COOL.

Parameters

runNumber	run number
lvl1Menu	L1 Menu

Definition at line 497 of file TrigConfCoolWriter.cxx.

                                                                                {
   RunRangeVec runRanges;
   runRanges.push_back(std::pair<unsigned int,unsigned int>(runNumber,runNumber));
   writeL1MonPayload( runRanges, lvl1Menu);
}

writeL1Payload()

void TrigConfCoolWriter::writeL1Payload	(	ValidityRange	vr,
		const CTPConfig &	ctpConfig )

Definition at line 304 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_WRITE);
   TrigConfCoolFolderSpec::createFolderStructure(m_dbPtr); // just in case
   try {
      writeL1MenuPayload         (vr, ctpConfig.menu());
      writeL1BunchGroupRunPayload(vr, ctpConfig.menu(), ctpConfig.bunchGroupSet() ); // writes bunchgroup description folder
      writeL1BunchGroupLBPayload (vr, ctpConfig.bunchGroupSet().id(), ctpConfig.bunchGroupSet()); // writes bunchgroup content and key folders
      writeL1PrescalePayload(vr.since(), vr.until(), ctpConfig.prescaleSet().id(), ctpConfig.prescaleSet());
   }
   catch(exception & e) {
      m_ostream << "<writeL1Payload> caught and re-throw exception: " << e.what() << endl;
      throw;
   }
}

writeL1PrescalePayload() [1/3]

void TrigConfCoolWriter::writeL1PrescalePayload	(	const RunRangeVec &	runRanges,
		unsigned int	lvl1PrescaleKey,
		const TrigConf::PrescaleSet &	prescale )

Definition at line 1170 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_WRITE);
   TrigConfCoolFolderSpec::createFolderStructure(m_dbPtr);
   for ( RunRange rr : runRanges) {
      ValidityRange vr(rr);
      writeL1PrescalePayload( vr.since(), vr.until(), lvl1PrescaleKey, prescale);
   }
}

writeL1PrescalePayload() [2/3]

void TrigConf::TrigConfCoolWriter::writeL1PrescalePayload	(	cool::ValidityKey	since,
		cool::ValidityKey	until,
		unsigned int	lvl1PrescaleKey,
		const TrigConf::PrescaleSet &	prescaleSet )

Definition at line 1195 of file TrigConfCoolWriter.cxx.

{
   prescaleSet.print("",5);
   AutoDBOpen db(this, READ_WRITE);
   // writing configuration keys and prescales
   try {
      IFolderPtr lvl1CkConfFolder = TrigConfCoolFolderSpec::getLvl1ConfKeyFolder(m_dbPtr);
      if( shouldFolderBeUpdated("/TRIGGER/LVL1/Lvl1ConfigKey") ) {
         rangeInfo("LVL1 prescale key", since, until);
         cool::Record payload =
            TrigConfCoolL1PayloadConverters::createLvl1ConfigKeyPayload(lvl1CkConfFolder, lvl1PrescaleKey);
         m_ostream << "Store LVL1 prescale key " << lvl1PrescaleKey << " to /TRIGGER/LVL1/Lvl1ConfigKey" << endl;
         lvl1CkConfFolder->storeObject(since, until, payload, 0);
      }
 
      if( shouldFolderBeUpdated("/TRIGGER/LVL1/Prescales") ) {
         rangeInfo("LVL1 prescale set", since, until);
         IFolderPtr lvl1PsConfFolder = TrigConfCoolFolderSpec::getLvl1PrescalesFolder(m_dbPtr);
         vector<int32_t> prescaleV = prescaleSet.cuts();
 
         vector<int32_t>::const_iterator psIt = prescaleV.begin();
 
         // use buffer to speed up COOL writing
         lvl1PsConfFolder->setupStorageBuffer();
 
         m_ostream << "Writing (to buffer) LVL1 prescales [(value/channel)]:" << endl;
         for(int channel=0; psIt != prescaleV.end(); channel++, ++psIt) {
            Record payload =
               TrigConfCoolL1PayloadConverters::createLvl1PrescalesPayload(lvl1PsConfFolder, *psIt);
            lvl1PsConfFolder->storeObject(since, until, payload, channel);
            m_ostream << "(" << *psIt << "/" << channel << ") ";
            if((channel+1)%10==0) m_ostream << endl;
         }
         m_ostream << "]" << endl;
         m_ostream << "Flushing LVL1 prescales buffer to /TRIGGER/LVL1/Prescales" << endl;
         lvl1PsConfFolder->flushStorageBuffer();
      }
   }
   catch(std::exception & e) {
      m_ostream << "<writeL1PrescalePayload> caught and re-throw exception: " << e.what() << endl;
      throw;
   }
 
}

writeL1PrescalePayload() [3/3]

void TrigConfCoolWriter::writeL1PrescalePayload	(	unsigned int	runNumber,
		unsigned int	lumiblockNumber,
		unsigned int	lvl1PrescaleKey,
		const TrigConf::PrescaleSet &	prescale )

Writing luminosityblock-wise configuration information the COOL database.

Parameters

runNumber	run number
lumiblockNumber	luminosity block number
hltpsk	HLT prescale configuration key
prescale	L1 prescale configuration object

Definition at line 1184 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_WRITE);
   TrigConfCoolFolderSpec::createFolderStructure(m_dbPtr); 
   ValidityRange vr(run, lb);
   writeL1PrescalePayload( vr.since(), vr.until(), lvl1PrescaleKey, prescaleSet);
}

writeMCKPayload()

void TrigConf::TrigConfCoolWriter::writeMCKPayload	(	ValidityRange	vr,
		unsigned int	mck,
		std::string &	release,
		std::string &	info )

Definition at line 425 of file TrigConfCoolWriter.cxx.

{
    AutoDBOpen db(this, READ_WRITE);
    TrigConfCoolFolderSpec::createFolderStructure(m_dbPtr); // just in case
    
    // writing monitoring configuration key
    if( shouldFolderBeUpdated("/TRIGGER/HLT/MenuAwareMonConfigKey") ) {
        rangeInfo("Monitoring configuration key", vr.since(), vr.until());
        try {
            IFolderPtr monconfkeyFolder = TrigConfCoolFolderSpec::getMonConfKeyFolder(m_dbPtr);
            Record     payload = createMonConfigKeyPayload(monconfkeyFolder, mck, info);
            monconfkeyFolder->storeObject(vr.since(), vr.until(), payload, 0, "MenuAwareMonConfigKey-"+release); //tag
            }
        catch(exception & e) {
            m_ostream << "<writeMCKPayload> caught and re-throw exception: " << e.what() << endl
            << "WARNING: Failed to write monitoring configuration key (MCK) to COOL" << endl;
            throw;
        }
    }
 
}

writeRunPayload() [1/2]

void TrigConfCoolWriter::writeRunPayload	(	const RunRangeVec &	runRanges,
		unsigned int	masterConfigKey,
		unsigned int	hltPrescaleKey,
		const TrigConf::ThresholdConfig &	lvl1Thr,
		const TrigConf::CTPConfig &	ctpConfig,
		const TrigConf::CaloInfo &	caloInfo,
		const TrigConf::HLTFrame &	hltFrame,
		const std::string &	configSource )

Definition at line 471 of file TrigConfCoolWriter.cxx.

{
   AutoDBOpen db(this, READ_WRITE);
   TrigConfCoolFolderSpec::createFolderStructure(m_dbPtr); // just in case
 
   for ( RunRange rr : runRanges) {
      writeL1Payload(rr, ctpConfig);
   }
 
   // loop over the run ranges
   for ( RunRange rr : runRanges) {
      writeHLTPayload( ValidityRange(rr), hltFrame, configSource);
   }
}

writeRunPayload() [2/2]

void TrigConfCoolWriter::writeRunPayload	(	unsigned int	runNumber,
		unsigned int	masterConfigKey,
		unsigned int	hltPrescaleKey,
		const TrigConf::ThresholdConfig &	lvl1Thr,
		const TrigConf::CTPConfig &	ctpConfig,
		const TrigConf::CaloInfo &	caloInfo,
		const TrigConf::HLTFrame &	hltFrame,
		const std::string &	configSource )

Writing run-wise configuration information the COOL database.

Parameters

runNumber	run number
masterConfigKey	configuration super master key
hltPrescaleKey	HLT prescale configuration key
lvl1Thr	L1 threshold configuration object
ctpConfig	L1 CTP configuration object
caloInfo	L1 calorimeter configuration object
hltFrame	HLT menu configuration object
configSource	configuration source (DB connection string or XML file name(s))

Definition at line 455 of file TrigConfCoolWriter.cxx.

{
   RunRangeVec runRanges;
   runRanges.push_back(std::pair<unsigned int,unsigned int>(runNumber,runNumber));
   writeRunPayload( runRanges, masterConfigKey, hltPrescaleKey, lvl1Thr, ctpConfig, caloInfo, hltFrame, configSource);
}

Friends And Related Symbol Documentation

AutoDBOpen

friend class AutoDBOpen

friend

Definition at line 390 of file TrigConfCoolWriter.h.

Member Data Documentation

m_coolApp

cool::Application TrigConf::TrigConfCoolWriter::m_coolApp

private

COOL application.

Definition at line 441 of file TrigConfCoolWriter.h.

m_dbId

cool::DatabaseId TrigConf::TrigConfCoolWriter::m_dbId

private

db connection string

Definition at line 439 of file TrigConfCoolWriter.h.

m_dbPtr

cool::IDatabasePtr TrigConf::TrigConfCoolWriter::m_dbPtr

private

COOL database pointer.

Definition at line 440 of file TrigConfCoolWriter.h.

m_ostream

std::ostream& TrigConf::TrigConfCoolWriter::m_ostream

private

output stream for all messages

Definition at line 444 of file TrigConfCoolWriter.h.

m_verbosityLevel

int TrigConf::TrigConfCoolWriter::m_verbosityLevel {0}

private

Definition at line 446 of file TrigConfCoolWriter.h.

{0};

m_writeFolderList

std::vector<std::string> TrigConf::TrigConfCoolWriter::m_writeFolderList

private

list of folders to which writing is restricted

Definition at line 443 of file TrigConfCoolWriter.h.

---

The documentation for this class was generated from the following files:

• TrigConfCoolWriter.h
• TrigConfCoolWriter.cxx