ATLAS Offline Software
Loading...
Searching...
No Matches
Public Member Functions | Protected Attributes | Private Member Functions | Private Attributes | List of all members
TrigConf::MuctpiLoader Class Reference

#include <MuctpiLoader.h>

Inheritance diagram for TrigConf::MuctpiLoader:
Collaboration diagram for TrigConf::MuctpiLoader:

Public Member Functions

 MuctpiLoader (StorageMgr &sm, coral::ISessionProxy &session)
virtual ~MuctpiLoader () override=default
virtual bool load (Muctpi &data) override
virtual void setLevel (MSGTC::Level lvl) override
 access to output stream
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

Definition at line 26 of file MuctpiLoader.h.

Constructor & Destructor Documentation

◆ MuctpiLoader()

TrigConf::MuctpiLoader::MuctpiLoader ( StorageMgr & sm,
coral::ISessionProxy & session )
inline

Definition at line 29 of file MuctpiLoader.h.

29: DBLoader(sm, session) {}
TrigConf::DBLoader::DBLoader
DBLoader(StorageMgr &sm, coral::ISessionProxy &session)
constructor
Definition DBLoader.cxx:30

◆ ~MuctpiLoader()

virtual TrigConf::MuctpiLoader::~MuctpiLoader ( )
overridevirtualdefault

Member Function Documentation

◆ commitSession()

void TrigConf::DBLoader::commitSession ( )
inherited

commit session if not already done

Definition at line 45 of file DBLoader.cxx.

46{
47 if ( m_session.transaction().isActive() && m_sessionOwner) {
48 m_session.transaction().commit();
49 }
50}
TrigConf::DBLoader::m_sessionOwner
bool m_sessionOwner
remember if the loader started the session in the first place
Definition DBLoader.h:69
TrigConf::DBLoader::m_session
coral::ISessionProxy & m_session
CORAL interface to database session.
Definition DBLoader.h:68

◆ getName()

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

name accessor

Returns
the name

Definition at line 101 of file TrigConfMessaging.h.

101 {
102 return m_name;
103 }

◆ isRun1()

bool TrigConf::DBLoader::isRun1 ( )
inlineinherited

Definition at line 60 of file DBLoader.h.

60{ return ! isRun2(); }

◆ isRun2()

bool DBLoader::isRun2 ( )
inherited

Definition at line 54 of file DBLoader.cxx.

54 {
55 const static unsigned int run = std::get<1>(loadSchemaVersion());
56 return run == 2;
57}
TrigConf::DBLoader::loadSchemaVersion
std::tuple< unsigned int, unsigned int > loadSchemaVersion() const
get DB schema version and run number
Definition DBLoader.cxx:81

◆ load()

bool TrigConf::MuctpiLoader::load ( Muctpi & data)
overridevirtual

Implements TrigConf::IMuctpiLoader.

Definition at line 38 of file MuctpiLoader.cxx.

38 {
39
40 if(verbose())
41 msg() << "MuctpiLoader: Loading MuCTPi with ID = " << mTarget.id() << " and Lvl1 masterId = " << mTarget.lvl1MasterTableId() << std::endl;
42 try {
43 startSession();
44 if ( mTarget.lvl1MasterTableId() ) {
45 // get the muctpi id for this mastertable
46 long muctpi_id = 0;
47
48 std::unique_ptr<coral::IQuery> query0(m_session.nominalSchema().tableHandle("L1_MASTER_TABLE").newQuery());
49 query0->setRowCacheSize( 5 );
50
51 //Bind list
52 coral::AttributeList bindList;
53 bindList.extend<long>("mtId");
54 std::string cond = "L1MT_ID = :mtId";
55 bindList[0].data<long>() = mTarget.lvl1MasterTableId();
56 query0->setCondition( cond, bindList );
57
58 //Output data and types
59 coral::AttributeList attList;
60 attList.extend<long>( "L1MT_MUCTPI_INFO_ID" );
61 query0->defineOutput(attList);
62 query0->addToOutputList( "L1MT_MUCTPI_INFO_ID" );
63
64 coral::ICursor& cursor0 = query0->execute();
65
66 if ( ! cursor0.next() ) {
67 msg() << "MuctpiLoader >> No such Master_Table exists " << mTarget.lvl1MasterTableId() << std::endl;
68 commitSession();
69 throw std::runtime_error( "MuctpiLoader >> Muctpi_Info not available" );
70 }
71
72 const coral::AttributeList& row0 = cursor0.currentRow();
73 muctpi_id = row0["L1MT_MUCTPI_INFO_ID"].data<long>();
74
75 if ( cursor0.next() ) {
76 msg() << "MuctpiLoader >> More than one Muctpi_Info exists for this master_table id"
77 << mTarget.lvl1MasterTableId() << std::endl;
78 commitSession();
79 throw std::runtime_error( "MuctpiLoader >> Muctpi_Info not available" );
80 }
81 mTarget.setId(muctpi_id);
82 }
83
84 std::unique_ptr<coral::IQuery> query(m_session.nominalSchema().tableHandle( "L1_MUCTPI_INFO").newQuery());
85 query->setRowCacheSize( 5 );
86
87 //Bind list
88 coral::AttributeList bindList2;
89 bindList2.extend<long>("miId");
90 std::string cond2 = "L1MI_ID = :miId";
91 bindList2[0].data<long>() = mTarget.id();
92 query->setCondition( cond2, bindList2 );
93
94 //Output data and types
95 coral::AttributeList attList;
96 attList.extend<int>( "L1MI_VERSION" );
97 attList.extend<std::string>( "L1MI_NAME" );
98 attList.extend<int>( "L1MI_LOW_PT" );
99 attList.extend<int>( "L1MI_HIGH_PT" );
100 attList.extend<int>( "L1MI_MAX_CAND" );
101 attList.extend<long>( "L1MI_ID" );
102 query->defineOutput(attList);
103
104 query->addToOutputList( "L1MI_VERSION" );
105 query->addToOutputList( "L1MI_NAME" );
106 query->addToOutputList( "L1MI_LOW_PT" );
107 query->addToOutputList( "L1MI_HIGH_PT" );
108 query->addToOutputList( "L1MI_MAX_CAND" );
109 query->addToOutputList( "L1MI_ID" );
110 query->addToOrderList( "L1MI_ID" );
111
112 coral::ICursor& cursor = query->execute();
113 if ( ! cursor.next() ) {
114 msg() << "MuctpiLoader >> No such Muctpi_info exists " << mTarget.id() << std::endl;
115 commitSession();
116 throw std::runtime_error( "MuctpiLoader >> Muctpi not available" );
117 }
118
119 const coral::AttributeList& row = cursor.currentRow();
120 std::string name = row["L1MI_NAME"].data<std::string>();
121 int version = row["L1MI_VERSION"].data<int>();
122 int low_pt = row["L1MI_LOW_PT"].data<int>();
123 int high_pt = row["L1MI_HIGH_PT"].data<int>();
124 int max_cand = row["L1MI_MAX_CAND"].data<int>();
125
126 if ( cursor.next() ) {
127 msg() << "MuctpiLoader >> More than one Muctpi exists " << mTarget.id() << std::endl;
128 commitSession();
129 throw std::runtime_error( "MuctpiLoader >> Muctpi not available" );
130 }
131
132
133 // Fill the object with data
134 mTarget.setName( name );
135 mTarget.setVersion( version );
136 mTarget.setLowptThreshold( low_pt );
137 mTarget.setHighptThreshold( high_pt );
138 mTarget.setMaxCand( max_cand );
139 commitSession();
140 return true;
141 } catch( const coral::SchemaException& e ) {
142 msg() << "MuctpiLoader >> SchemaException: " << e.what() << std::endl;
143 m_session.transaction().rollback();
144 return false;
145 } catch( const std::exception& e ) {
146 msg() << "MuctpiLoader >> Standard C++ exception: " << e.what() << std::endl;
147 m_session.transaction().rollback();
148 return false;
149
150 } catch( ... ) {
151 msg() << "MuctpiLoader >> unknown C++ exception" << std::endl;
152 m_session.transaction().rollback();
153 return false;
154 }
155}
TrigConf::DBLoader::verbose
virtual int verbose() const override
Definition DBLoader.h:57
TrigConf::DBLoader::commitSession
void commitSession()
commit session if not already done
Definition DBLoader.cxx:45
TrigConf::DBLoader::startSession
void startSession()
start session if not already active
Definition DBLoader.cxx:35
TrigConf::TrigConfMessaging::msg
MsgStreamTC & msg() const
The standard message stream.
Definition TrigConfMessaging.h:86
PrintTrkAnaSummary.row
row
Appending html table to final .html summary file.
Definition PrintTrkAnaSummary.py:356
get_generator_info.version
version
Definition get_generator_info.py:33
index.query
query
Definition index.py:72

◆ loadL1MasterKey()

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

get l1 master from super master

Definition at line 128 of file DBLoader.cxx.

128 {
129 try {
130 startSession();
131
132 unique_ptr< coral::IQuery > q( m_session.nominalSchema().tableHandle( "SUPER_MASTER_TABLE").newQuery() );
133 q->setRowCacheSize( 5 );
134
135 //Bind list
136 coral::AttributeList bindings;
137 bindings.extend<int>("smtid");
138 bindings[0].data<int>() = smk;
139 q->setCondition( "SMT_ID = :smtid", bindings );
140
141 //Output data and types
142 coral::AttributeList attList;
143 attList.extend<int>( "SMT_L1_MASTER_TABLE_ID" );
144 fillQuery(q.get(), attList);
145
146 coral::ICursor& cursor = q->execute();
147 if ( ! cursor.next() ) {
148 msg() << "DBLoader: No such SuperMaster key exists " << smk << endl;
149 throw runtime_error( "DBLoader: SuperMasterKey not available" );
150 }
151
152 const coral::AttributeList& row = cursor.currentRow();
153 Lvl1MasterKey = row["SMT_L1_MASTER_TABLE_ID"].data<int>();
154 }
155 catch( const std::exception& e ) {
156 commitSession();
157 msg() << "DBLoader: C++ exception: " << e.what() << std::endl;
158 throw;
159 }
160 commitSession();
161 return true;
162}
TrigConf::fillQuery
void fillQuery(coral::IQuery *q, coral::AttributeList &attList)
Definition DBHelper.cxx:13
trigbs_dumpHLTContentInBS.smk
smk
Definition trigbs_dumpHLTContentInBS.py:92

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

167 {
168 try {
169
170 int l1Master = 0;
171 loadL1MasterKey(SuperMasterKey, l1Master);
172
173 startSession();
174
175 unique_ptr< coral::IQuery > q( m_session.nominalSchema().tableHandle( "L1_MASTER_TABLE").newQuery() );
176 q->setRowCacheSize( 5 );
177
178 //Bind list
179 coral::AttributeList bindings;
180 bindings.extend<int>("l1mtid");
181 bindings[0].data<int>() = l1Master;
182 q->setCondition( "L1MT_ID = :l1mtid" , bindings );
183
184 //Output data and types
185 coral::AttributeList attList;
186 attList.extend<int>( "L1MT_TRIGGER_MENU_ID" );
187 q->defineOutput(attList);
188 q->addToOutputList( "L1MT_TRIGGER_MENU_ID" );
189
190 coral::ICursor& cursor = q->execute();
191 if ( ! cursor.next() ) {
192 msg() << "DBLoader >> No such L1 Master key exists " << l1Master << std::endl;
193 throw std::runtime_error( "DBLoader >> L1MasterKey not available" );
194 commitSession();
195 }
196
197 const coral::AttributeList& row = cursor.currentRow();
198 Lvl1MenuKey = row["L1MT_TRIGGER_MENU_ID"].data<int>();
199
200 commitSession();
201
202 }
203 catch( const std::exception& e ) {
204 msg() << "DBLoader >> Standard C++ exception: " << e.what() << std::endl;
205 m_session.transaction().rollback();
206 throw;
207 }
208 return true;
209}
TrigConf::DBLoader::loadL1MasterKey
bool loadL1MasterKey(int SuperMasterKey, int &Lvl1MasterKey)
get l1 master from super master
Definition DBLoader.cxx:128

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

82{
83 const static auto versions = [&]() -> std::tuple<unsigned int,unsigned int> {
84 bool mySession = false;
85 if ( ! m_session.transaction().isActive() ) {
86 m_session.transaction().start(true);
87 mySession = true;
88 }
89
90 std::unique_ptr< coral::IQuery > q( m_session.nominalSchema().tableHandle( "TRIGGER_SCHEMA").newQuery() );
91 q->setRowCacheSize( 1 );
92
93 //Output data and types
94 coral::AttributeList attList;
95 attList.extend<int>( "TS_ID" );
96 q->defineOutput(attList);
97 q->addToOutputList( "TS_ID" );
98
99 q->addToOrderList("TS_ID desc");
100 coral::ICursor& cursor = q->execute();
101
102 if ( ! cursor.next() ) {
103 TRG_MSG_ERROR("Table TRIGGER_SCHEMA is not filled");
104 if ( mySession ) m_session.transaction().commit();
105 throw std::runtime_error( "DBLoader::loadSchemaVersion() >> Table TRIGGER_SCHEMA is not filled" );
106 }
107
108 const coral::AttributeList& row = cursor.currentRow();
109 const unsigned int triggerDBSchemaVersion = row["TS_ID"].data<int>();
110
111 TRG_MSG_INFO("TriggerDB schema version: " << triggerDBSchemaVersion);
112
113 const unsigned int run = m_session.nominalSchema().existsTable( "ACTIVE_MASTERS" ) ? 2 : 1;
114
115 TRG_MSG_INFO("Database has Run " << run << " schema");
116 TRG_MSG_INFO("Total number of tables : " << m_session.nominalSchema().listTables().size());
117
118 //commitSession();
119 if ( mySession ) m_session.transaction().commit();
120
121 return {triggerDBSchemaVersion, run};
122 }();
123
124 return versions;
125}
TrigConf::DBLoader::triggerDBSchemaVersion
unsigned int triggerDBSchemaVersion()
Definition DBLoader.cxx:76

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

87 {
88 MsgStreamTC* ms = m_msg_tls.get();
89 if (!ms) {
90 ms = new MsgStreamTC(m_name);
91 m_msg_tls.reset(ms);
92 }
93 return *ms;
94 }
TrigConf::TrigConfMessaging::m_msg_tls
boost::thread_specific_ptr< MsgStreamTC > m_msg_tls
MsgStreamTC instance (a std::cout like with print-out levels)
Definition TrigConfMessaging.h:71

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

97 {
98 return msg() << lvl;
99 }

◆ msgLvl()

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

Test the output level.

Parameters
lvlThe message level to test against
Returns
boolean Indicting if messages at given level will be printed
Return values
trueMessages at level "lvl" will be printed

Definition at line 75 of file TrigConfMessaging.h.

76 {
77 if (msg().level() <= lvl) {
78 msg() << lvl;
79 return true;
80 }
81 else {
82 return false;
83 }
84 }

◆ outputLevel()

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

Implements TrigConf::ILoader.

Definition at line 40 of file DBLoader.h.

40{ return msg().level(); }

◆ setLevel()

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

access to output stream

Implements TrigConf::ILoader.

Definition at line 60 of file DBLoader.cxx.

60 {
61 msg().setLevel(lvl);
62
63 switch(lvl) {
64 case MSGTC::ALWAYS: m_verbose = 5; break;
65 case MSGTC::VERBOSE: m_verbose = 4; break;
66 case MSGTC::DEBUG: m_verbose = 3; break;
67 case MSGTC::INFO: m_verbose = 2; break;
68 case MSGTC::WARNING:
69 case MSGTC::ERROR:
70 case MSGTC::FATAL: m_verbose = 0; break;
71 default: m_verbose = 0;
72 }
73}
TrigConf::MsgStreamTC::setLevel
void setLevel(MSGTC::Level lvl)
Set message level of stream.
Definition Trigger/TrigConfiguration/TrigConfBase/Root/MsgStream.cxx:52

◆ setVerbose()

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

Implements TrigConf::ILoader.

Definition at line 58 of file DBLoader.h.

58{ m_verbose=v; }

◆ startSession()

void TrigConf::DBLoader::startSession ( )
inherited

start session if not already active

Definition at line 35 of file DBLoader.cxx.

36{
37 if ( ! m_session.transaction().isActive() ) {
38 //std::cout << "DBLoader: startSession(readonly=true)" << std::endl;
39 bool readOnly = true;
40 m_session.transaction().start(readOnly);
41 m_sessionOwner = true;
42 }
43}

◆ triggerDBSchemaVersion()

unsigned int DBLoader::triggerDBSchemaVersion ( )
inherited

Definition at line 76 of file DBLoader.cxx.

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

◆ verbose()

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

Implements TrigConf::ILoader.

Definition at line 57 of file DBLoader.h.

57{ 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 68 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 69 of file DBLoader.h.

69{false};

◆ m_storageMgr

StorageMgr& TrigConf::DBLoader::m_storageMgr
protectedinherited

reference to the storage manager

Definition at line 67 of file DBLoader.h.

◆ m_verbose

int TrigConf::DBLoader::m_verbose {1}
privateinherited

Definition at line 64 of file DBLoader.h.

64{1};
The documentation for this class was generated from the following files:
Generated on for ATLAS Offline Software by doxygen 1.14.0