TrigConf::L1TopoMenuLoader Class Reference

TriggerDB loader of the HLT menu. More...

#include <L1TopoMenuLoader.h>

Inheritance diagram for TrigConf::L1TopoMenuLoader:

Collaboration diagram for TrigConf::L1TopoMenuLoader:

Public Member Functions
	L1TopoMenuLoader (StorageMgr &sm, coral::ISessionProxy &session)
	constructor
virtual	~L1TopoMenuLoader () override=default
	destructor
virtual bool	load (TXC::L1TopoMenu &) override
bool	loadTopoAlgos (TXC::L1TopoMenu &tcaTarget)
bool	loadOutputList (TXC::L1TopoMenu &tcaTarget, const int &ctplinkid)
bool	loadTopoConfig (TXC::L1TopoMenu &tcaTarget)
bool	loadAllAlgsInput (std::map< uint, TXC::L1TopoConfigAlg > &idToAlgMap)
bool	loadAllAlgsOutput (std::map< uint, TXC::L1TopoConfigAlg > &idToAlgMap)
bool	loadAllAlgsRegister (std::map< uint, TXC::L1TopoConfigAlg > &idToAlgMap)
bool	loadAllAlgsFixed (std::map< uint, TXC::L1TopoConfigAlg > &idToAlgMap)
virtual void	setLevel (MSGTC::Level lvl) override
	Load the configuration data from the configuration source.
virtual MSGTC::Level	outputLevel () const override
void	startSession ()
	start session if not already active
void	commitSession ()
	commit session if not already done
bool	loadL1MasterKey (int SuperMasterKey, int &Lvl1MasterKey)
	get l1 master from super master
bool	loadL1MenuKey (int SuperMasterKey, int &Lvl1MenuKey)
	get l1 menu id from super master
unsigned int	triggerDBSchemaVersion ()
virtual int	verbose () const override
virtual void	setVerbose (int v) override
bool	isRun1 ()
bool	isRun2 ()
bool	msgLvl (const MSGTC::Level lvl) const
	Test the output level.
MsgStreamTC &	msg () const
	The standard message stream.
MsgStreamTC &	msg (const MSGTC::Level lvl) const
	The standard message stream.
const std::string &	getName () const
	name accessor

Protected Attributes
StorageMgr &	m_storageMgr
	reference to the storage manager
coral::ISessionProxy &	m_session
	CORAL interface to database session.
bool	m_sessionOwner {false}
	remember if the loader started the session in the first place

Private Member Functions
std::tuple< unsigned int, unsigned int >	loadSchemaVersion () const
	get DB schema version and run number

Private Attributes
int	m_verbose {1}
boost::thread_specific_ptr< MsgStreamTC >	m_msg_tls
	MsgStreamTC instance (a std::cout like with print-out levels)
std::string	m_name

Detailed Description

TriggerDB loader of the HLT menu.

Definition at line 18 of file L1TopoMenuLoader.h.

Constructor & Destructor Documentation

L1TopoMenuLoader()

TrigConf::L1TopoMenuLoader::L1TopoMenuLoader ( StorageMgr & sm, coral::ISessionProxy & session )

inline

constructor

Parameters

sm	reference to storage manager
session	reference to the database session

Definition at line 26 of file L1TopoMenuLoader.h.

                                                                      :
         IL1TopoMenuLoader(), DBLoader("L1TopoMenuLoader", sm, session) {}

~L1TopoMenuLoader()

virtual TrigConf::L1TopoMenuLoader::~L1TopoMenuLoader ( )

overridevirtualdefault

destructor

Member Function Documentation

commitSession()

void TrigConf::DBLoader::commitSession ( )

inherited

commit session if not already done

Definition at line 45 of file DBLoader.cxx.

{
   if ( m_session.transaction().isActive() && m_sessionOwner) {
      m_session.transaction().commit();
   }
}

getName()

const std::string & TrigConf::TrigConfMessaging::getName ( ) const

inlineinherited

name accessor

Returns

the name

Definition at line 101 of file TrigConfMessaging.h.

                                                           {
    return m_name;
  }

isRun1()

bool TrigConf::DBLoader::isRun1 ( )

inlineinherited

Definition at line 59 of file DBLoader.h.

{ return ! isRun2(); }

isRun2()

bool DBLoader::isRun2 ( )

inherited

Definition at line 54 of file DBLoader.cxx.

                 {
   const static unsigned int run = std::get<1>(loadSchemaVersion());
   return run == 2;
}

load()

bool TrigConf::L1TopoMenuLoader::load ( TXC::L1TopoMenu & tcaTarget )

overridevirtual

Implements TrigConf::IL1TopoMenuLoader.

Definition at line 27 of file L1TopoMenuLoader.cxx.

                                                              {
   try {
     unsigned int schema = triggerDBSchemaVersion();
     TRG_MSG_DEBUG("L1TopoMenuLoader Run " << (isRun1()? 1 : 2) << ", schema version " << schema);
     if(isRun1()) {
        TRG_MSG_INFO("Not loading L1 TopoMenu from a run 1 database");
        return true;
     }
     TRG_MSG_INFO("Loading L1 TopoMenu with SMK " << tcaTarget.getSMK());
     startSession();
     loadTopoAlgos(tcaTarget);
     commitSession();
     if(msg().level() < TrigConf::MSGTC::INFO)
        tcaTarget.print();
   } catch( const std::exception& e ) {
      TRG_MSG_ERROR("L1TopoMenuLoader::load >> Standard C++ exception: " << e.what());
   } catch( ... ) {
      TRG_MSG_ERROR("L1TopoMenuLoader::load >> ... caught ");
   }
   TRG_MSG_INFO( "Loaded L1 TopoMenu with " << tcaTarget.getL1TopoConfigAlgs().size() << " algorithms and " 
                 << tcaTarget.getL1TopoConfigOutputList().getTriggerLines().size() << " trigger lines");
   return true;
}

loadAllAlgsFixed()

bool TrigConf::L1TopoMenuLoader::loadAllAlgsFixed

(

std::map< uint, TXC::L1TopoConfigAlg > &

idToAlgMap

)

Definition at line 383 of file L1TopoMenuLoader.cxx.

                                                                                          {
   TRG_MSG_VERBOSE("Calling loadAllAlgsFixed");
 
   set<uint> algIds;
   for( auto & e : idToAlgMap ) {
      algIds.insert(e.first);
   }
 
   string algIdsConc = "(";
   bool first = true;
   for( int id : algIds ) {
      if(first) { first = false; } else { algIdsConc += ","; }
      algIdsConc += to_string(id);
   }
   algIdsConc+=")";
 
   try {
      startSession();
      
      unique_ptr<coral::IQuery> query0(m_session.nominalSchema().newQuery());
      query0->addToTableList("TA_TO_TG","TA2TG");
      query0->addToTableList("TOPO_GENERIC","TG");
      //Bind list
      coral::AttributeList bindList0;
//       bindList0.extend<int>("taId");
//       bindList0[0].data<int>() = ta_id;
 
      string theCondition0 = "";
      theCondition0 += string(" TA2TG.TA2TG_ALGO_ID IN " + algIdsConc);
      theCondition0 += string(" AND TA2TG.TA2TG_GENERIC_ID = TG.TG_ID"); 
      query0->setCondition( theCondition0, bindList0 );
 
      query0->addToOrderList("TG.TG_NAME");
 
      coral::AttributeList attList0;
      attList0.extend<int>( "TA2TG.TA2TG_ALGO_ID" );
      attList0.extend<string>( "TG.TG_NAME" );
      attList0.extend<string>( "TG.TG_VALUE" );
      query0->defineOutput(attList0);     
      fillQuery(query0.get(), attList0);
      //std::cout << "Executing loadAlgFiexed query " << std::endl;
      coral::ICursor& cursor0 = query0->execute();
 
      uint fixedCount(0);
      while(cursor0.next()){
         fixedCount++;
         const coral::AttributeList& row0 = cursor0.currentRow();
         //std::cout << "loadAlgFixed my row " << row0 << std::endl;
         string tg_name = row0["TG.TG_NAME"].data<string>();
         string tg_value = row0["TG.TG_VALUE"].data<string>();
 
         // fill the alg
         int algoId = row0["TA2TG.TA2TG_ALGO_ID"].data<int>();
         auto match = idToAlgMap.find(algoId);
         if (match == idToAlgMap.end()) continue;
         TXC::L1TopoConfigAlg & alg = match->second;
         alg.addFixedParameter(tg_name,tg_value);
     }
 
      TRG_MSG_DEBUG("" << fixedCount << " Fixed found");
 
   } catch (const exception& e){
     TRG_MSG_ERROR("loadAlgFixed >> Standard C++ exception: " << e.what());
     return false;
   }
   return true;
 
}

loadAllAlgsInput()

bool TrigConf::L1TopoMenuLoader::loadAllAlgsInput

(

std::map< uint, TXC::L1TopoConfigAlg > &

idToAlgMap

)

Definition at line 153 of file L1TopoMenuLoader.cxx.

                                                                                              {
 
   TRG_MSG_VERBOSE("Calling loadAllAlgsInput");
 
   set<uint> algIds;
   for( auto & e : idToAlgMap ) {
      algIds.insert(e.first);
   }
 
   string algIdsConc = "(";
   bool first = true;
   for( int id : algIds ) {
      if(first) { first = false; } else { algIdsConc += ","; }
      algIdsConc += to_string(id);
   }
   algIdsConc+=")";
 
   TRG_MSG_DEBUG("" << algIds.size() << " algorithms ");
   TRG_MSG_VERBOSE("Alg IDs : " << algIdsConc);
 
   try {
      startSession();
      
      unique_ptr<coral::IQuery> query0(m_session.nominalSchema().newQuery());
      query0->addToTableList("TA_TO_TI","TA2TI");
      query0->addToTableList("TOPO_ALGO_INPUT","TAI");
      coral::AttributeList bindList0;
 
      string theCondition0 = "";
      theCondition0 += " TA2TI.TA2TI_ALGO_ID IN " + algIdsConc;
      theCondition0 += string(" AND TA2TI.TA2TI_INPUT_ID = TAI.TAI_ID"); 
      query0->setCondition( theCondition0, bindList0 );
 
      coral::AttributeList attList0;
      attList0.extend<int>( "TA2TI.TA2TI_ALGO_ID" );
      attList0.extend<string>( "TAI.TAI_NAME" );
      attList0.extend<string>( "TAI.TAI_VALUE" );
      attList0.extend<int>( "TAI.TAI_POSITION" );
      query0->defineOutput(attList0);     
      fillQuery(query0.get(), attList0);
      //std::cout << "Executing loadAlgInput query " << std::endl;
      coral::ICursor& cursor0 = query0->execute();
 
      uint inputCount = 0;
      while(cursor0.next()){
         inputCount ++;
 
         const coral::AttributeList& row0 = cursor0.currentRow();
 
         //std::cout << "loadAlgInput my row " << row0 << std::endl;
         string tai_name = row0["TAI.TAI_NAME"].data<string>();
         string tai_value = row0["TAI.TAI_VALUE"].data<string>();
         int tai_pos = row0["TAI.TAI_POSITION"].data<int>();
         if(tai_pos<0) tai_pos=0; // when position is missing in XML, currently the TT uploads -1 instead of 0
 
         // fill the alg
         int algoId = row0["TA2TI.TA2TI_ALGO_ID"].data<int>();
         auto match = idToAlgMap.find(algoId);
         if (match == idToAlgMap.end()) continue;
         TXC::L1TopoConfigAlg & alg = match->second;
         alg.addInput(tai_name,tai_value,tai_pos);
     }
 
      TRG_MSG_DEBUG("" << inputCount << " inputs found");
 
   } catch (const exception& e){
      TRG_MSG_ERROR("loadAlgInput >> Standard C++ exception: " << e.what());
      throw;
   }
   return true;
}

loadAllAlgsOutput()

bool TrigConf::L1TopoMenuLoader::loadAllAlgsOutput

(

std::map< uint, TXC::L1TopoConfigAlg > &

idToAlgMap

)

Definition at line 227 of file L1TopoMenuLoader.cxx.

                                                                                           {
   TRG_MSG_VERBOSE("Calling loadAllAlgsOutput");
 
   set<uint> algIds;
   for( auto & e : idToAlgMap ) {
      algIds.insert(e.first);
   }
 
   string algIdsConc = "(";
   bool first = true;
   for( int id : algIds ) {
      if(first) { first = false; } else { algIdsConc += ","; }
      algIdsConc += to_string(id);
   }
   algIdsConc+=")";
 
   try {
      startSession();
      unique_ptr<coral::IQuery> query0(m_session.nominalSchema().newQuery());
      query0->addToTableList("TOPO_ALGO","TA");
      query0->addToTableList("TA_TO_TO","TA2TO");
      query0->addToTableList("TOPO_ALGO_OUTPUT","TAO");
      //Bind list
      coral::AttributeList bindList0;
//       bindList0.extend<int>("taId");
//       bindList0[0].data<int>() = ta_id;
 
      string theCondition0 = "";
      theCondition0 += " TA.TA_ID IN " + algIdsConc;
      theCondition0 += " AND TA.TA_ID = TA2TO.TA2TO_ALGO_ID";
      theCondition0 += " AND TA2TO.TA2TO_OUTPUT_ID = TAO.TAO_ID";
      query0->setCondition( theCondition0, bindList0 );
 
      coral::AttributeList attList0;
      attList0.extend<int>( "TA2TO.TA2TO_ALGO_ID" );
      attList0.extend<string>( "TAO.TAO_NAME" );
      attList0.extend<string>( "TAO.TAO_VALUE" );
      attList0.extend<string>( "TAO.TAO_BITNAME" );
      attList0.extend<int>( "TAO.TAO_SELECTION" );
      attList0.extend<int>( "TA.TA_BITS" );
      query0->defineOutput(attList0);     
      fillQuery(query0.get(), attList0);
      //std::cout << "Executing loadAlgOutput query " << std::endl;
      coral::ICursor& cursor0 = query0->execute();
 
 
      uint outputCount = 0;
      while(cursor0.next()){
         outputCount ++;
 
         const coral::AttributeList& row0 = cursor0.currentRow();
         //std::cout << "loadAlgOutput my row " << row0 << std::endl;
         string tao_name = row0["TAO.TAO_NAME"].data<string>();
         string tao_value = row0["TAO.TAO_VALUE"].data<string>();
         string tao_bitname = row0["TAO.TAO_BITNAME"].data<string>();
         int tao_sel = row0["TAO.TAO_SELECTION"].data<int>();
         int ta_bits = row0["TA.TA_BITS"].data<int>();
 
         // fill the alg
         int algoId = row0["TA2TO.TA2TO_ALGO_ID"].data<int>();
         auto match = idToAlgMap.find(algoId);
         if (match == idToAlgMap.end()) continue;
         TXC::L1TopoConfigAlg & alg = match->second;
         alg.addOutput(tao_name,tao_value,ta_bits,tao_bitname, tao_sel);
     }
 
      TRG_MSG_DEBUG("" << outputCount << " outputs found");
 
   } catch (const exception& e){
      TRG_MSG_ERROR("loadAlgOutput >> Standard C++ exception: " << e.what());
      throw;
   }
   return true;
}

loadAllAlgsRegister()

bool TrigConf::L1TopoMenuLoader::loadAllAlgsRegister

(

std::map< uint, TXC::L1TopoConfigAlg > &

idToAlgMap

)

Definition at line 305 of file L1TopoMenuLoader.cxx.

                                                                                             {
 
   TRG_MSG_VERBOSE("Calling loadAllAlgsRegister");
 
   set<uint> algIds;
   for( auto & e : idToAlgMap ) {
      algIds.insert(e.first);
   }
 
   string algIdsConc = "(";
   bool first = true;
   for( int id : algIds ) {
      if(first) { first = false; } else { algIdsConc += ","; }
      algIdsConc += to_string(id);
   }
   algIdsConc+=")";
 
   try {
      startSession();
      
      unique_ptr<coral::IQuery> query0(m_session.nominalSchema().newQuery());
      query0->addToTableList("TA_TO_TP","TA2TP");
      query0->addToTableList("TOPO_PARAMETER","TP");
      //Bind list
      coral::AttributeList bindList0;
//       bindList0.extend<int>("taId");
//       bindList0[0].data<int>() = ta_id;
 
      string theCondition0 = "";
      theCondition0 += " TA2TP.TA2TP_ALGO_ID IN " + algIdsConc;
      theCondition0 += " AND TA2TP.TA2TP_PARAM_ID = TP.TP_ID"; 
      query0->setCondition( theCondition0, bindList0 );
 
      coral::AttributeList attList0;
      attList0.extend<int>( "TA2TP.TA2TP_ALGO_ID" );
      attList0.extend<string>( "TP.TP_NAME" );
      attList0.extend<long>( "TP.TP_VALUE" );
      attList0.extend<int>( "TP.TP_POSITION" );
      attList0.extend<int>( "TP.TP_SELECTION" );
      query0->defineOutput(attList0);
      fillQuery(query0.get(), attList0);
      //std::cout << "Executing loadAlgRegister query " << std::endl;
      coral::ICursor& cursor0 = query0->execute();
 
      uint registerCount(0);
      while(cursor0.next()){
         registerCount++;
         const coral::AttributeList& row0 = cursor0.currentRow();
         //std::cout << "loadAlgRegister my row " << row0 << std::endl;
         string tp_name = row0["TP.TP_NAME"].data<string>();
         long tp_value = row0["TP.TP_VALUE"].data<long>();
         int tp_pos = row0["TP.TP_POSITION"].data<int>();
         int tp_sel = row0["TP.TP_SELECTION"].data<int>();
         if(tp_pos<0) tp_pos=0;
         if(tp_sel<0) tp_sel=0;
 
 
         // fill the alg
         int algoId = row0["TA2TP.TA2TP_ALGO_ID"].data<int>();
         auto match = idToAlgMap.find(algoId);
         if (match == idToAlgMap.end()) continue;
         TXC::L1TopoConfigAlg & alg = match->second;
         alg.addParameter(tp_name,to_string(tp_value),tp_pos, tp_sel);
     }
 
      TRG_MSG_DEBUG("" << registerCount << " registers found");
 
   } catch (const exception& e){
      TRG_MSG_ERROR("loadAlgRegister >> Standard C++ exception: " << e.what());
      throw;
   }
   return true;
}

loadL1MasterKey()

bool TrigConf::DBLoader::loadL1MasterKey ( int SuperMasterKey, int & Lvl1MasterKey )

inherited

get l1 master from super master

Definition at line 128 of file DBLoader.cxx.

                                                             {
   try {
      startSession();
      
      unique_ptr< coral::IQuery > q( m_session.nominalSchema().tableHandle( "SUPER_MASTER_TABLE").newQuery() );
      q->setRowCacheSize( 5 );
 
      //Bind list
      coral::AttributeList bindings;
      bindings.extend<int>("smtid");
      bindings[0].data<int>() = smk;
      q->setCondition( "SMT_ID = :smtid", bindings );
 
      //Output data and types
      coral::AttributeList attList;
      attList.extend<int>( "SMT_L1_MASTER_TABLE_ID" );
      fillQuery(q.get(), attList);
 
      coral::ICursor& cursor = q->execute();
      if ( ! cursor.next() ) {
         msg() << "DBLoader:           No such SuperMaster key exists " << smk << endl;
         throw runtime_error( "DBLoader:        SuperMasterKey not available" );
      }
    
      const coral::AttributeList& row = cursor.currentRow();
      Lvl1MasterKey = row["SMT_L1_MASTER_TABLE_ID"].data<int>();
   }
   catch( const std::exception& e ) {
      commitSession();
      msg() << "DBLoader:         C++ exception: " << e.what() << std::endl;
      throw;
   }
   commitSession();
   return true; 
}

loadL1MenuKey()

bool TrigConf::DBLoader::loadL1MenuKey ( int SuperMasterKey, int & Lvl1MenuKey )

inherited

get l1 menu id from super master

Definition at line 167 of file DBLoader.cxx.

                                                                    {
   try {
 
      int l1Master = 0;
      loadL1MasterKey(SuperMasterKey, l1Master);
 
      startSession();
    
      unique_ptr< coral::IQuery > q( m_session.nominalSchema().tableHandle( "L1_MASTER_TABLE").newQuery() );
      q->setRowCacheSize( 5 );
 
      //Bind list
      coral::AttributeList bindings;
      bindings.extend<int>("l1mtid");
      bindings[0].data<int>() = l1Master;
      q->setCondition( "L1MT_ID = :l1mtid" , bindings );
 
      //Output data and types
      coral::AttributeList attList;
      attList.extend<int>( "L1MT_TRIGGER_MENU_ID" );
      q->defineOutput(attList);
      q->addToOutputList( "L1MT_TRIGGER_MENU_ID" );
 
      coral::ICursor& cursor = q->execute();
      if ( ! cursor.next() ) {
         msg() << "DBLoader >> No such L1 Master key exists " << l1Master << std::endl;
         throw std::runtime_error( "DBLoader >> L1MasterKey not available" );
      }
    
      const coral::AttributeList& row = cursor.currentRow();
      Lvl1MenuKey = row["L1MT_TRIGGER_MENU_ID"].data<int>();
 
      commitSession();
 
   }
   catch( const std::exception& e ) {
      msg() << "DBLoader >> Standard C++ exception: " << e.what() << std::endl;
      m_session.transaction().rollback();
      throw;
   }
   return true; 
}

loadOutputList()

bool TrigConf::L1TopoMenuLoader::loadOutputList	(	TXC::L1TopoMenu &	tcaTarget,
		const int &	ctplinkid )

Definition at line 625 of file L1TopoMenuLoader.cxx.

                                                                                             {
   try {
      TRG_MSG_VERBOSE("Calling loadOutputList");
      startSession();
      
      unique_ptr<coral::IQuery> query0(m_session.nominalSchema().newQuery());
      query0->addToTableList("TOPO_OUTPUT_LIST","TOL");
      query0->addToTableList("TOPO_OUTPUT_LINK","TOLK");
      query0->addToTableList("TOPO_OUTPUT_LINE","TOLINE");
      //Bind list
      coral::AttributeList bindList0;
      bindList0.extend<int>("ctpLId");
      bindList0[0].data<int>() = ctplinkid;
 
      string theCondition0 = "";
      theCondition0 += string(" TOL.OL_ID = :ctpLId" );
      theCondition0 += string(" AND TOLK.TL_LINK_ID = TOL.OL_ID"); 
      theCondition0 += string(" AND TOLK.TL_OUTPUT_ID = TOLINE.TOL_ID"); 
      query0->setCondition( theCondition0, bindList0 );
 
      coral::AttributeList attList0;
      attList0.extend<int>( "TOLINE.TOL_ID" );
      attList0.extend<string>( "TOLINE.TOL_ALGO_NAME" );
      attList0.extend<string>( "TOLINE.TOL_TRIGGERLINE" );
      attList0.extend<unsigned int>( "TOLINE.TOL_ALGO_ID" );
      attList0.extend<unsigned int>( "TOLINE.TOL_MODULE" );
      attList0.extend<unsigned int>( "TOLINE.TOL_FPGA" );
      attList0.extend<unsigned int>( "TOLINE.TOL_FIRST_BIT" );
      attList0.extend<unsigned int>( "TOLINE.TOL_CLOCK" );
      query0->defineOutput(attList0);     
      fillQuery(query0.get(), attList0);
      //std::cout << "Executing loadAlgFiexed query " << std::endl;
      coral::ICursor& cursor0 = query0->execute();
      while(cursor0.next()){
         const coral::AttributeList& row0 = cursor0.currentRow();
         //std::cout << "loadOutputList my row " << row0 << std::endl;
         string tol_name = row0["TOLINE.TOL_ALGO_NAME"].data<string>();
         unsigned int tol_algoId = row0["TOLINE.TOL_ALGO_ID"].data<unsigned int>();
         unsigned int tol_module = row0["TOLINE.TOL_MODULE"].data<unsigned int>();
         unsigned int tol_fpga = row0["TOLINE.TOL_FPGA"].data<unsigned int>();
         unsigned int tol_clock = row0["TOLINE.TOL_CLOCK"].data<unsigned int>();
         unsigned int tol_firstbit = row0["TOLINE.TOL_FIRST_BIT"].data<unsigned int>();
         tcaTarget.addL1TopoXMLOutput(TXC::OutputListElement( tol_name, tol_algoId, tol_module, tol_fpga, tol_clock, tol_firstbit));
     }
     tcaTarget.setTriggerList();
   } catch (const exception& e){
     TRG_MSG_ERROR("loadOutputList >> Standard C++ exception: " << e.what());
     throw;
   }
   return true;
}

loadSchemaVersion()

std::tuple< unsigned int, unsigned int > DBLoader::loadSchemaVersion ( ) const

privateinherited

get DB schema version and run number

Definition at line 81 of file DBLoader.cxx.

{
   const static auto versions = [&]() -> std::tuple<unsigned int,unsigned int> {
      bool mySession = false;
      if ( ! m_session.transaction().isActive() ) {
         m_session.transaction().start(true);
         mySession = true;
      }
 
      std::unique_ptr< coral::IQuery > q( m_session.nominalSchema().tableHandle( "TRIGGER_SCHEMA").newQuery() );
      q->setRowCacheSize( 1 );
 
      //Output data and types
      coral::AttributeList attList;
      attList.extend<int>( "TS_ID" );
      q->defineOutput(attList);
      q->addToOutputList( "TS_ID" );
 
      q->addToOrderList("TS_ID desc");
      coral::ICursor& cursor = q->execute();
 
      if ( ! cursor.next() ) {
         TRG_MSG_ERROR("Table TRIGGER_SCHEMA is not filled");
         if ( mySession ) m_session.transaction().commit();
         throw std::runtime_error( "DBLoader::loadSchemaVersion() >> Table TRIGGER_SCHEMA is not filled" );
      }
 
      const coral::AttributeList& row = cursor.currentRow();
      const unsigned int triggerDBSchemaVersion = row["TS_ID"].data<int>();
 
      TRG_MSG_INFO("TriggerDB schema version: " << triggerDBSchemaVersion);
 
      const unsigned int run = m_session.nominalSchema().existsTable( "ACTIVE_MASTERS" ) ? 2 : 1;
 
      TRG_MSG_INFO("Database has Run " << run << " schema");
      TRG_MSG_INFO("Total number of tables : " <<  m_session.nominalSchema().listTables().size());
 
      //commitSession();
      if ( mySession ) m_session.transaction().commit();
 
      return {triggerDBSchemaVersion, run};
   }();
 
   return versions;
}

loadTopoAlgos()

bool TrigConf::L1TopoMenuLoader::loadTopoAlgos

(

TXC::L1TopoMenu &

tcaTarget

)

Definition at line 52 of file L1TopoMenuLoader.cxx.

                                                                      {
 
   TRG_MSG_VERBOSE("Calling loadTopoAlgos for SMK " << tcaTarget.getSMK());
      
   try {
      startSession();
      
      unique_ptr<coral::IQuery> query0(m_session.nominalSchema().newQuery());
      query0->addToTableList("SUPER_MASTER_TABLE","SM");
      query0->addToTableList("TOPO_MASTER_TABLE","TMT");
      query0->addToTableList("TOPO_TRIGGER_MENU","TTM");
      query0->addToTableList("TTM_TO_TA","TTM2TA");
      query0->addToTableList("TOPO_ALGO","TA");
      query0->setRowCacheSize(1000);
    
      //Bind list
      coral::AttributeList bindList0;
      bindList0.extend<unsigned int>("tmtId");
      std::string cond = "TMT_ID = :tmtId";
      bindList0[0].data<unsigned int>() = tcaTarget.getSMK();
 
      string theCondition0 = "";
      theCondition0 += string(" SM.SMT_ID = :tmtId");
      theCondition0 += string(" AND TMT.TMT_ID = SM.SMT_TOPO_MASTER_TABLE_ID "); 
      theCondition0 += string(" AND TTM.TTM_ID = TMT.TMT_TRIGGER_MENU_ID ");
      theCondition0 += string(" AND TTM2TA.TTM2TA_MENU_ID = TTM.TTM_ID "); 
      theCondition0 += string(" AND TA.TA_ID = TTM2TA.TTM2TA_ALGO_ID "); 
      query0->setCondition( theCondition0, bindList0 );
 
      coral::AttributeList attList0;
 
      //TMT.TMT_TRIGGER_MENU_ID, TMT.TMT_VERSION,TTM.TTM_NAME,TTM.TTM_VERSION,TTM.TTM_CTPLINK_ID,TA.TA_ID,TA.TA_NAME,TA.TA_OUTPUT,TA.TA_TYPE,TA.TA_BITS,TA.TA_SORT_DECI,TA.TA_ALGO_ID
      //attList0.extend<int>( "TMT.TMT_TRIGGER_MENU_ID" );
      //attList0.extend<long>( "TMT.TMT_VERSION" );
      attList0.extend<string>( "TTM.TTM_NAME" );
      //attList0.extend<int>( "TTM.TTM_VERSION" );
      attList0.extend<int>( "TTM.TTM_CTPLINK_ID" );
      attList0.extend<int>( "TA.TA_ID" );
      attList0.extend<string>( "TA.TA_NAME" );
      attList0.extend<string>( "TA.TA_OUTPUT" );
      attList0.extend<string>( "TA.TA_TYPE" );
      attList0.extend<int>( "TA.TA_BITS" );
      attList0.extend<string>( "TA.TA_SORT_DECI" );
      attList0.extend<int>( "TA.TA_ALGO_ID" );
      query0->defineOutput(attList0);     
      fillQuery(query0.get(), attList0);
      TRG_MSG_VERBOSE("Executing loadTopoAlgos query ");
      coral::ICursor& cursor0 = query0->execute();
 
      int ctplinkid = 0;
 
      std::map<uint, TXC::L1TopoConfigAlg> idToAlgMap; // map of id -> alg for later bulk loading of inputs, outputs, etc.
 
      while(cursor0.next()){
         const coral::AttributeList& row0 = cursor0.currentRow();
         int ta_id = row0["TA.TA_ID"].data<int>();
         string ta_name = row0["TA.TA_NAME"].data<string>();
         string ta_output = row0["TA.TA_OUTPUT"].data<string>();
         string ta_type = row0["TA.TA_TYPE"].data<string>();
         //int ta_bits = row0["TA.TA_BITS"].data<int>();
         string ta_sort_deci = row0["TA.TA_SORT_DECI"].data<string>();
         int ta_algo_id = row0["TA.TA_ALGO_ID"].data<int>();
         ctplinkid = row0["TTM.TTM_CTPLINK_ID"].data<int>();
         tcaTarget.setName(row0["TTM.TTM_NAME"].data<string>());
         tcaTarget.setVersion(std::to_string(ta_id));
 
 
         TXC::L1TopoConfigAlg alg(ta_name,ta_type);
         if(ta_sort_deci=="Decision") alg.setAlgKind(TXC::L1TopoConfigAlg::DECISION);
         else if(ta_sort_deci=="Sort") alg.setAlgKind(TXC::L1TopoConfigAlg::SORT);
         else alg.setAlgKind(TXC::L1TopoConfigAlg::NONE);
         alg.setAlgOutput(ta_output);
         alg.setAlgoID(ta_algo_id);
         // loadAlgInput(alg,ta_id);
         // loadAlgOutput(alg,ta_id,ta_bits);
         // loadAlgRegister(alg, ta_id);
         // loadAlgFixed(alg, ta_id);
         idToAlgMap.emplace(ta_id,std::move(alg));
         // tcaTarget.addAlgorithm(alg);
      }
 
      loadAllAlgsInput(idToAlgMap);
      loadAllAlgsOutput(idToAlgMap);
      loadAllAlgsRegister(idToAlgMap);
      loadAllAlgsFixed(idToAlgMap);
 
      for( auto & e : idToAlgMap ) {
         tcaTarget.addAlgorithm(std::move(e.second));
      }
      idToAlgMap.clear();//invalid aftermove
      loadTopoConfig(tcaTarget);
      loadOutputList(tcaTarget,ctplinkid);
   } catch( const std::exception& e ) {
      TRG_MSG_ERROR("loadTopoAlgos >> Standard C++ exception: " << e.what());
      commitSession();
      throw;
   }
   return true;
}

loadTopoConfig()

bool TrigConf::L1TopoMenuLoader::loadTopoConfig

(

TXC::L1TopoMenu &

tcaTarget

)

Definition at line 677 of file L1TopoMenuLoader.cxx.

                                                                       {
 
   try {
      TRG_MSG_VERBOSE("Calling loadTopoConfig");
      startSession();
      
      unique_ptr<coral::IQuery> query0(m_session.nominalSchema().newQuery());
      query0->addToTableList("SUPER_MASTER_TABLE","SM");
      query0->addToTableList("TOPO_MASTER_TABLE","TMT");
      query0->addToTableList("TOPO_TRIGGER_MENU","TTM");
      query0->addToTableList("TTM_TO_TC","TTM2TC");
      query0->addToTableList("TOPO_CONFIG","TC");
      query0->setRowCacheSize(5);
    
      //Bind list
      coral::AttributeList bindList0;
      bindList0.extend<unsigned int>("tmtId");
      std::string cond = "TMT_ID = :tmtId";
      bindList0[0].data<unsigned int>() = tcaTarget.getSMK();
 
      string theCondition0 = "";
      theCondition0 += string(" SM.SMT_ID = :tmtId");
      theCondition0 += string(" AND TMT.TMT_ID = SM.SMT_TOPO_MASTER_TABLE_ID "); 
      theCondition0 += string(" AND TTM.TTM_ID = TMT.TMT_TRIGGER_MENU_ID ");
      theCondition0 += string(" AND TTM2TC.TTM2TC_ID = TTM.TTM_ID ");
      theCondition0 += string(" AND TC.TC_ID = TTM2TC.TTM2TC_CONFIG_ID ");
      query0->setCondition( theCondition0, bindList0 );
 
      coral::AttributeList attList0;
      attList0.extend<string>( "TC.TC_NAME" ); 
      attList0.extend<string>( "TC.TC_VALUE" );
      query0->defineOutput(attList0);     
      fillQuery(query0.get(), attList0);
      coral::ICursor& cursor0 = query0->execute();
 
      while(cursor0.next()){
         const coral::AttributeList& row0 = cursor0.currentRow();
 
         string tc_name = row0["TC.TC_NAME"].data<string>();
         string tc_value = row0["TC.TC_VALUE"].data<string>();
 
         tcaTarget.addL1TopoConfigGlobal(TXC::TopoConfigElement(tc_name,tc_value));
      }
 
   } catch( const std::exception& e ) {
      TRG_MSG_ERROR("loadTopoConfig >> Standard C++ exception: " << e.what());
      commitSession();
      throw;
   }
   return true;
}

msg() [1/2]

MsgStreamTC & TrigConf::TrigConfMessaging::msg ( ) const

inlineinherited

The standard message stream.

Returns a reference to the message stream May not be invoked before sysInitialize() has been invoked.

Definition at line 86 of file TrigConfMessaging.h.

  {
    MsgStreamTC* ms = m_msg_tls.get();
    if (!ms) {
      ms = new MsgStreamTC(m_name);
      m_msg_tls.reset(ms);
    }
    return *ms;
  }

msg() [2/2]

MsgStreamTC & TrigConf::TrigConfMessaging::msg ( const MSGTC::Level lvl ) const

inlineinherited

The standard message stream.

Returns a reference to the default message stream May not be invoked before sysInitialize() has been invoked.

Definition at line 96 of file TrigConfMessaging.h.

  {
    return msg() << lvl;
  }

msgLvl()

bool TrigConf::TrigConfMessaging::msgLvl ( const MSGTC::Level lvl ) const

inlineinherited

Test the output level.

Parameters

lvl	The message level to test against

Returns

boolean Indicting if messages at given level will be printed

Return values

true	Messages at level "lvl" will be printed

Definition at line 75 of file TrigConfMessaging.h.

  {
    if (msg().level() <= lvl) {
      msg() << lvl;
      return true;
    }
    else {
      return false;
    }
  }

outputLevel()

virtual MSGTC::Level TrigConf::DBLoader::outputLevel ( ) const

inlineoverridevirtualinherited

Implements TrigConf::ILoader.

Definition at line 39 of file DBLoader.h.

{ return msg().level(); }

setLevel()

void DBLoader::setLevel ( MSGTC::Level lvl )

overridevirtualinherited

Load the configuration data from the configuration source.

Parameters

ctpc	reference to the data object to be filled

Returns

true if the loading was successful, false otherwise

Implements TrigConf::ILoader.

Definition at line 60 of file DBLoader.cxx.

                                 {
   msg().setLevel(lvl);
 
   switch(lvl) {
   case MSGTC::ALWAYS: m_verbose = 5; break;
   case MSGTC::VERBOSE: m_verbose = 4; break;
   case MSGTC::DEBUG: m_verbose = 3; break;
   case MSGTC::INFO: m_verbose = 2; break;
   case MSGTC::WARNING:
   case MSGTC::ERROR:
   case MSGTC::FATAL: m_verbose = 0; break;
   default: m_verbose = 0;
   }
}

setVerbose()

virtual void TrigConf::DBLoader::setVerbose ( int v )

inlineoverridevirtualinherited

Implements TrigConf::ILoader.

Definition at line 57 of file DBLoader.h.

{ m_verbose=v; }

startSession()

void TrigConf::DBLoader::startSession ( )

inherited

start session if not already active

Definition at line 36 of file DBLoader.cxx.

{
   if ( ! m_session.transaction().isActive() ) {
      bool readOnly = true;
      m_session.transaction().start(readOnly);
      m_sessionOwner = true;
   }
}

triggerDBSchemaVersion()

unsigned int DBLoader::triggerDBSchemaVersion ( )

inherited

Definition at line 76 of file DBLoader.cxx.

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

verbose()

virtual int TrigConf::DBLoader::verbose ( ) const

inlineoverridevirtualinherited

Implements TrigConf::ILoader.

Definition at line 56 of file DBLoader.h.

{ return m_verbose; }

Member Data Documentation

m_msg_tls

boost::thread_specific_ptr<MsgStreamTC> TrigConf::TrigConfMessaging::m_msg_tls

mutableprivateinherited

MsgStreamTC instance (a std::cout like with print-out levels)

Definition at line 71 of file TrigConfMessaging.h.

m_name

std::string TrigConf::TrigConfMessaging::m_name

privateinherited

Definition at line 72 of file TrigConfMessaging.h.

m_session

coral::ISessionProxy& TrigConf::DBLoader::m_session

protectedinherited

CORAL interface to database session.

Definition at line 67 of file DBLoader.h.

m_sessionOwner

bool TrigConf::DBLoader::m_sessionOwner {false}

protectedinherited

remember if the loader started the session in the first place

Definition at line 68 of file DBLoader.h.

{false}; 

m_storageMgr

StorageMgr& TrigConf::DBLoader::m_storageMgr

protectedinherited

reference to the storage manager

Definition at line 66 of file DBLoader.h.

m_verbose

int TrigConf::DBLoader::m_verbose {1}

privateinherited

Definition at line 63 of file DBLoader.h.

{1};

---

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

• L1TopoMenuLoader.h
• L1TopoMenuLoader.cxx