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

#include <LutCamLoader.h>

Inheritance diagram for TrigConf::LutCamLoader:
Collaboration diagram for TrigConf::LutCamLoader:

Public Member Functions

 LutCamLoader (StorageMgr &sm, coral::ISessionProxy &session)
virtual ~LutCamLoader () override=default
virtual bool load (LutCam &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

template<class T>
bool convert_hex_string (T &t, const std::string &s)
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 17 of file LutCamLoader.h.

Constructor & Destructor Documentation

◆ LutCamLoader()

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

Definition at line 20 of file LutCamLoader.h.

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

◆ ~LutCamLoader()

virtual TrigConf::LutCamLoader::~LutCamLoader ( )
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

◆ convert_hex_string()

template<class T>
bool TrigConf::LutCamLoader::convert_hex_string ( T & t,
const std::string & s )
inlineprivate

Definition at line 29 of file LutCamLoader.h.

30 {
31 std::istringstream iss(s);
32 return !(iss >> std::hex >> t).fail();
33 }
beamspotman.fail
fail(message)
Definition beamspotman.py:197
read_hist_ntuple.t
t
Definition read_hist_ntuple.py:5

◆ 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::LutCamLoader::load ( LutCam & data)
overridevirtual

Implements TrigConf::ILutCamLoader.

Definition at line 36 of file LutCamLoader.cxx.

36 {
37
38 msg() << "LutCamLoader started loading data via ID. ID = " << lTarget.id() << std::endl;
39 try {
40 startSession();
41 msg() << "Loading LutCam " << lTarget.id() << std::endl;
42
43 coral::ITable& table = m_session.nominalSchema().tableHandle( "L1_CTP_FILES");
44 coral::IQuery* query = table.newQuery();
45 query->setRowCacheSize( 5 );
46
47 std::string condition= "L1CF_ID = :l1cfid";
48
49 coral::AttributeList boundvars;
50 boundvars.extend<int>("l1cfid");
51 boundvars[0].data<int>() = lTarget.id();
52
53 query->setCondition( condition, boundvars );
54
55 query->addToOutputList( "L1CF_NAME" );
56 query->addToOutputList( "L1CF_VERSION" );
57 query->addToOutputList( "L1CF_LUT" );
58 query->addToOutputList( "L1CF_CAM" );
59
60 coral::ICursor& cursor = query->execute();
61
62 if ( ! cursor.next() ) {
63 msg() << "LutCamLoader >> No such L1_CTP_Files exists " << lTarget.id() << std::endl;
64 delete query;
65 commitSession();
66 throw std::runtime_error( "LutCamLoader >> LutCam not available" );
67 }
68
69 const coral::AttributeList& row = cursor.currentRow();
70
71 std::string name = "";
72 name = row["L1CF_NAME"].data<std::string>();
73 int version = 0;
74 version = row["L1CF_VERSION"].data<int>();
75 std::string lut_str ="";
76 lut_str = row["L1CF_LUT"].data<std::string>();
77 std::string cam_str ="";
78 cam_str = row["L1CF_CAM"].data<std::string>();
79
80 if ( cursor.next() ) {
81 msg() << "LutCamLoader >> More than one LutCam exists " << lTarget.id() << std::endl;
82 delete query;
83 commitSession();
84 throw std::runtime_error( "LutCamLoader >> LutCam not available" );
85 }
86
87 // transform strings to arrays of integers
88
89 u_int lut_int[LutCam::ALL_LUT_SIZE];
90 u_int significantBits = 8; // eight hex digits
91 u_int preFix = 2; // 0x
92 u_int postFix = 1; // termination
93 u_int wordsize = (preFix + significantBits + postFix);
94 for(u_int i=0; i<LutCam::ALL_LUT_SIZE; i++) {
95
96 u_int tmp_data;
97
98 // // this loop is extremely slow!!
99 // std::sscanf(lut_str.substr(i*wordsize,wordsize).c_str(),"%x",&data);
100 // lut_int[i]=data;
101
102 // this loop is even slower (about 20%), but at least type safe!
103 if(!convert_hex_string<u_int>(tmp_data, lut_str.substr(i*wordsize+preFix,significantBits))) {
104 msg() << "LutCamLoader>> Conversion of LUT no" << i << " failed! Read string " << lut_str.substr(i*wordsize+preFix,significantBits) << std::endl;
105 msg() << "TEST: substr(0,24): " << lut_str.substr(0,24) << " - substr(14,8): " << lut_str.substr(14,8) << " cc : " << (i*wordsize+preFix) << std::endl;
106 commitSession();
107 throw std::runtime_error( "LutCamLoader >> LUT conversion failed." );
108 }
109 lut_int[i] = tmp_data;
110 }
111 u_int cam_int[LutCam::ALL_CAM_SIZE] = {90, 90, 90, 90, 90, 90};
112 for(u_int i=0; i<LutCam::ALL_CAM_SIZE; i++) {
113
114 u_int tmp_data;
115
116 // std::sscanf(cam_str.substr(i*wordsize,wordsize).c_str(),"%x",&data);
117
118 if(!convert_hex_string<u_int>(tmp_data, cam_str.substr(i*wordsize+preFix,significantBits))) {
119 msg() << "LutCamLoader>> Conversion of CAM no" << i << " failed!" << std::endl;
120 commitSession();
121 throw std::runtime_error( "LutCamLoader >> CAM conversion failed." );
122 }
123 cam_int[i]=tmp_data;
124 }
125
126 // Fill the object with data
127 lTarget.setName( name );
128 lTarget.setVersion( version );
129 lTarget.setLut(lut_int, LutCam::ALL_LUT_SIZE);
130 lTarget.setCam(cam_int, LutCam:: ALL_CAM_SIZE);
131
132 delete query;
133 commitSession();
134 return true;
135 }
136 catch( const coral::SchemaException& e )
137 {
138 msg() << "LutCamLoader >> SchemaException: "
139 << e.what() << std::endl;
140 commitSession();
141 return false;
142 }
143 catch( const std::exception& e )
144 {
145 msg() << "LutCamLoader >> Standard C++ exception: " << e.what() << std::endl;
146 commitSession();
147 return false;
148 }
149 catch( ... )
150 {
151 msg() << "LutCamLoader >> unknown C++ exception" << std::endl;
152 commitSession();
153 return false;
154 }
155}
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::LutCamLoader::convert_hex_string
bool convert_hex_string(T &t, const std::string &s)
Definition LutCamLoader.h:29
TrigConf::LutCam::ALL_CAM_SIZE
static const u_int ALL_CAM_SIZE
Definition LutCam.h:21
TrigConf::LutCam::ALL_LUT_SIZE
static const u_int ALL_LUT_SIZE
Definition LutCam.h:20
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
python.ext.table_printer.table
list table
Definition table_printer.py:78

◆ 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