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

#include <BunchGroupSetLoader.h>

Inheritance diagram for TrigConf::BunchGroupSetLoader:
Collaboration diagram for TrigConf::BunchGroupSetLoader:

Public Member Functions

 BunchGroupSetLoader (StorageMgr &sm, coral::ISessionProxy &session)
virtual ~BunchGroupSetLoader () override=default
virtual bool load (BunchGroupSet &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 28 of file BunchGroupSetLoader.h.

Constructor & Destructor Documentation

◆ BunchGroupSetLoader()

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

Definition at line 31 of file BunchGroupSetLoader.h.

31 :
32 DBLoader("BunchGroupSetLoader", sm, session) {}
TrigConf::DBLoader::DBLoader
DBLoader(StorageMgr &sm, coral::ISessionProxy &session)
constructor
Definition DBLoader.cxx:30

◆ ~BunchGroupSetLoader()

virtual TrigConf::BunchGroupSetLoader::~BunchGroupSetLoader ( )
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::BunchGroupSetLoader::load ( BunchGroupSet & data)
overridevirtual

Implements TrigConf::IBunchGroupSetLoader.

Definition at line 18 of file BunchGroupSetLoader.cxx.

18 {
19
20 TRG_MSG_INFO("Loading BunchGroupSet with ID = " << data.id());
21 try {
22
23 {
24 startSession();
25 unique_ptr<coral::IQuery> q(m_session.nominalSchema().tableHandle( "L1_BUNCH_GROUP_SET").newQuery());
26 q->setRowCacheSize( 5 );
27
28 //Bind list
29 coral::AttributeList bindList;
30 bindList.extend<int>("bgsId");
31 bindList[0].data<int>() = (int)data.id();
32 q->setCondition( "L1BGS_ID = :bgsId", bindList );
33
34 //Output data and types
35 coral::AttributeList attList;
36 attList.extend<std::string>( "L1BGS_NAME" );
37 attList.extend<int>( "L1BGS_VERSION" );
38 attList.extend<std::string>( "L1BGS_COMMENT" );
39 fillQuery(q.get(),attList);
40
41 coral::ICursor& cursor = q->execute();
42
43 if ( ! cursor.next() ) {
44 TRG_MSG_ERROR("No such BGS exists " << data.id());
45 commitSession();
46 throw std::runtime_error( "BunchGroupSetLoader >> BunchGroupSet not available" );
47 }
48
49 const coral::AttributeList& row = cursor.currentRow();
50 string name = row["L1BGS_NAME"].data<std::string>();
51 int version = row["L1BGS_VERSION"].data<int>();
52 string comment = row["L1BGS_COMMENT"].data<std::string>();
53
54 if ( cursor.next() ) {
55 TRG_MSG_ERROR("More than one BunchGroupSet exists " << data.id());
56 commitSession();
57 throw std::runtime_error( "BunchGroupSetLoader >> BunchGroupSet not available" );
58 }
59
60 // fill the object with data
61 data.setName( name );
62 data.setVersion( version );
63 data.setComment( comment );
64 }
65
66 // now touch the l1_bgs_to_bg table to get the bunch groups.
67 {
68 unique_ptr<coral::IQuery> q( m_session.nominalSchema().tableHandle( "L1_BGS_TO_BG").newQuery() );
69 q->setRowCacheSize( 5 );
70
71 //binding
72 coral::AttributeList bindList;
73 bindList.extend<int>("bgsId");
74 bindList[0].data<int>() = (int)data.id();
75 q->setCondition( "L1BGS2BG_BUNCH_GROUP_SET_ID = :bgsId ", bindList );
76
77 //Output data and types
78 coral::AttributeList attList;
79 attList.extend<long>( "L1BGS2BG_BUNCH_GROUP_ID" );
80 attList.extend<long>( "L1BGS2BG_INTERNAL_NUMBER" );
81 if(isRun2()) {
82 attList.extend<string>( "L1BGS2BG_BUNCH_GROUP_NAME" );
83 }
84 fillQuery(q.get(),attList);
85
86 q->addToOrderList( "L1BGS2BG_INTERNAL_NUMBER" );
87
88 coral::ICursor& cursor = q->execute();
89
90 BunchGroupLoader& bgldr = dynamic_cast<BunchGroupLoader&>(dynamic_cast<StorageMgr&>(m_storageMgr).bunchGroupLoader() );
91 while( cursor.next() ) {
92 BunchGroup bg;
93 const coral::AttributeList& row = cursor.currentRow();
94
95 bg.setId(row["L1BGS2BG_BUNCH_GROUP_ID"].data<long>());
96 bg.setInternalNumber( row["L1BGS2BG_INTERNAL_NUMBER"].data<long>() );
97 if(isRun2()) {
98 bg.setName( row["L1BGS2BG_BUNCH_GROUP_NAME"].data<string>() );
99 }
100 if ( !bgldr.load( bg ) ) {
101 TRG_MSG_ERROR("loading BunchGroup " << bg.id() );
102 commitSession();
103 throw std::runtime_error( "BunchGroupSetLoader: Error loading BunchGroup" );
104 }
105
106 data.addBunchGroup(bg);
107 }
108 commitSession();
109 }
110
111 }
112 catch( const coral::Exception& e ) {
113 TRG_MSG_ERROR("Coral::Exception: " << e.what());
114 m_session.transaction().rollback();
115 throw;
116 }
117
118 return true;
119}
data
char data[hepevt_bytes_allocation_ATLAS]
Definition HepEvt.cxx:11
TrigConf::DBLoader::m_storageMgr
StorageMgr & m_storageMgr
reference to the storage manager
Definition DBLoader.h:67
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
CaloCondBlobAlgs_fillNoiseFromASCII.comment
str comment
Definition CaloCondBlobAlgs_fillNoiseFromASCII.py:26
PrintTrkAnaSummary.row
row
Appending html table to final .html summary file.
Definition PrintTrkAnaSummary.py:356
TrigConf::fillQuery
void fillQuery(coral::IQuery *q, coral::AttributeList &attList)
Definition DBHelper.cxx:13
get_generator_info.version
version
Definition get_generator_info.py:33

◆ 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::TrigConfMessaging::msg
MsgStreamTC & msg() const
The standard message stream.
Definition TrigConfMessaging.h:86
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