Skip to content
Snippets Groups Projects
Commit d7bf3442 authored by Tomasz Bold's avatar Tomasz Bold Committed by Frank Winklmeier
Browse files

Write Json Run 3 config from TrigConfReadWrite utility

parent eb12b181
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
Trigger/TrigConfiguration/TrigConfStorage/CMakeLists.txt
+ 3
− 3
View file @ d7bf3442
...@@ -15,7 +15,7 @@ atlas_add_library( TrigConfStorage ...@@ -15,7 +15,7 @@ atlas_add_library( TrigConfStorage
PUBLIC_HEADERS TrigConfStorage PUBLIC_HEADERS TrigConfStorage
INCLUDE_DIRS ${Boost_INCLUDE_DIRS} ${COOL_INCLUDE_DIRS} ${CORAL_INCLUDE_DIRS} INCLUDE_DIRS ${Boost_INCLUDE_DIRS} ${COOL_INCLUDE_DIRS} ${CORAL_INCLUDE_DIRS}
PRIVATE_INCLUDE_DIRS ${TDAQ-COMMON_INCLUDE_DIRS} PRIVATE_INCLUDE_DIRS ${TDAQ-COMMON_INCLUDE_DIRS}
LINK_LIBRARIES ${Boost_LIBRARIES} ${COOL_LIBRARIES} TrigConfBase TrigConfHLTData TrigConfL1Data LINK_LIBRARIES ${Boost_LIBRARIES} ${COOL_LIBRARIES} TrigConfBase TrigConfHLTData TrigConfL1Data TrigConfData
PRIVATE_LINK_LIBRARIES ${CORAL_LIBRARIES} ${TDAQ-COMMON_LIBRARIES} TrigConfJobOptData L1TopoConfig ) PRIVATE_LINK_LIBRARIES ${CORAL_LIBRARIES} ${TDAQ-COMMON_LIBRARIES} TrigConfJobOptData L1TopoConfig )
atlas_add_executable( TrigConf2COOLApp atlas_add_executable( TrigConf2COOLApp
...@@ -27,8 +27,8 @@ atlas_add_executable( TrigConfConsistencyChecker ...@@ -27,8 +27,8 @@ atlas_add_executable( TrigConfConsistencyChecker
LINK_LIBRARIES TrigConfStorage ) LINK_LIBRARIES TrigConfStorage )
atlas_add_executable( TrigConfReadWrite atlas_add_executable( TrigConfReadWrite
src/test/ReadWrite.cxx src/test/ReadWrite.cxx src/test/Run2toRun3Converters.cxx
LINK_LIBRARIES L1TopoConfig TrigConfJobOptData TrigConfStorage ) LINK_LIBRARIES L1TopoConfig TrigConfJobOptData TrigConfStorage TrigConfData TrigConfIO TrigCompositeUtilsLib )
atlas_add_executable( TrigConfCoolFix atlas_add_executable( TrigConfCoolFix
src/test/CoolFix.cxx src/test/CoolFix.cxx
......
Trigger/TrigConfiguration/TrigConfStorage/src/test/ReadWrite.cxx
+ 60
− 42
View file @ d7bf3442
...@@ -3,14 +3,14 @@ ...@@ -3,14 +3,14 @@
*/ */
///////////////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////////////////
// //
// NAME: TrigConfReadWrite.cxx // NAME: TrigConfReadWrite.cxx
// PACKAGE: TrigConfStorage // PACKAGE: TrigConfStorage
// //
// AUTHOR: J.Stelzer (CERN) Joerg.Stelzer@cern.ch // AUTHOR: J.Stelzer (CERN) Joerg.Stelzer@cern.ch
// CREATED: 17 Mar 2013 // CREATED: 17 Mar 2013
// //
// PURPOSE: // PURPOSE:
// //
// This standalone application is designed to read and write the // This standalone application is designed to read and write the
// trigger configuration (L1+HLT) from DB,XML,COOL and to XML or COOL // trigger configuration (L1+HLT) from DB,XML,COOL and to XML or COOL
...@@ -42,6 +42,8 @@ ...@@ -42,6 +42,8 @@
#include "TrigConfHLTData/HLTPrescaleSet.h" #include "TrigConfHLTData/HLTPrescaleSet.h"
#include "TrigConfJobOptData/JobOptionTable.h" #include "TrigConfJobOptData/JobOptionTable.h"
#include "Run2toRun3Converters.h"
#include "CoolKernel/DatabaseId.h" #include "CoolKernel/DatabaseId.h"
#include "CoolKernel/Exception.h" #include "CoolKernel/Exception.h"
#include "CoolKernel/IDatabaseSvc.h" #include "CoolKernel/IDatabaseSvc.h"
...@@ -60,10 +62,11 @@ ...@@ -60,10 +62,11 @@
#include <ctime> #include <ctime>
#include <map> #include <map>
#include <vector> #include <vector>
#include <sys/stat.h> #include <sys/stat.h>
using namespace std; using namespace std;
using namespace TrigConf; using namespace TrigConf;
HLTMenu convertRun2HLTtoRun3(const HLTFrame* frame);
void printhelp(std::ostream & o, std::ostream& (*lineend) ( std::ostream& os )) { void printhelp(std::ostream & o, std::ostream& (*lineend) ( std::ostream& os )) {
o << "================================================================================\n"; o << "================================================================================\n";
...@@ -73,7 +76,7 @@ void printhelp(std::ostream & o, std::ostream& (*lineend) ( std::ostream& os )) ...@@ -73,7 +76,7 @@ void printhelp(std::ostream & o, std::ostream& (*lineend) ( std::ostream& os ))
o << "[Global options]\n"; o << "[Global options]\n";
o << " -i|--input input [input [input]] ... source of configuration, format see below (mandatory)\n"; o << " -i|--input input [input [input]] ... source of configuration, format see below (mandatory)\n";
o << " -2|--comp input [input [input]] ... source of a second configuration for comparison\n"; o << " -2|--comp input [input [input]] ... source of a second configuration for comparison\n";
o << " -o|--output xml|cool [output[;cooldb]] [run] ... output format, name (for cool optional run number)\n"; o << " -o|--output xml|r3json|cool [output[;cooldb]] [run] ... output format, name (for cool optional run number)\n";
o << " ... absolute output file name must contain '/', cooldb can be appended COMP200|OFLP200\n"; o << " ... absolute output file name must contain '/', cooldb can be appended COMP200|OFLP200\n";
o << " -v|--loglevel <string> ... log level [NIL, VERBOSE, DEBUG, INFO, WARNING, ERROR, FATAL, ALWAYS]\n"; o << " -v|--loglevel <string> ... log level [NIL, VERBOSE, DEBUG, INFO, WARNING, ERROR, FATAL, ALWAYS]\n";
o << " -l|--log <string> ... name of a log file\n"; o << " -l|--log <string> ... name of a log file\n";
...@@ -100,6 +103,7 @@ void printhelp(std::ostream & o, std::ostream& (*lineend) ( std::ostream& os )) ...@@ -100,6 +103,7 @@ void printhelp(std::ostream & o, std::ostream& (*lineend) ( std::ostream& os ))
o << " -o xml test ... will produce LVL1config_test.xml and/or HLTconfig_test.xml. When\n"; o << " -o xml test ... will produce LVL1config_test.xml and/or HLTconfig_test.xml. When\n";
o << " comparing two menus this will produce Diff_test.xml. In this case the\n"; o << " comparing two menus this will produce Diff_test.xml. In this case the\n";
o << " specification of '-o test' is sufficient\n"; o << " specification of '-o test' is sufficient\n";
o << " -o r3json test ... will produce Run3 JSON LVL1Menu_test.json and HLTMenu_test.json\n";
o << " -o cool ... will produce trig_cool.db with cool db instance CONDBR2 and infinite IOV\n"; o << " -o cool ... will produce trig_cool.db with cool db instance CONDBR2 and infinite IOV\n";
o << " -o cool 200000 ... will produce trig_cool.db with cool db instance CONDBR2 and run number 200000\n"; o << " -o cool 200000 ... will produce trig_cool.db with cool db instance CONDBR2 and run number 200000\n";
o << " -o cool test [200000] ... will produce trig_cool_test.db with cool db instance CONDBR2 [and run number 200000]\n"; o << " -o cool test [200000] ... will produce trig_cool_test.db with cool db instance CONDBR2 [and run number 200000]\n";
...@@ -111,7 +115,7 @@ void printhelp(std::ostream & o, std::ostream& (*lineend) ( std::ostream& os )) ...@@ -111,7 +115,7 @@ void printhelp(std::ostream & o, std::ostream& (*lineend) ( std::ostream& os ))
class JobConfig { class JobConfig {
public: public:
enum Format { UNDEF=0x00, DB=0x01, COOL=0x02, XML=0x04 }; enum Format { UNDEF=0x00, DB=0x01, COOL=0x02, XML=0x04, JSON=0x08 };
enum ETriggerLevel { LVL1 = 0, HLT = 1, NONE = 2 }; enum ETriggerLevel { LVL1 = 0, HLT = 1, NONE = 2 };
~JobConfig(){} ~JobConfig(){}
JobConfig() {} JobConfig() {}
...@@ -127,6 +131,7 @@ public: ...@@ -127,6 +131,7 @@ public:
string l1xmlOutFile { "LVL1Config.xml" }; string l1xmlOutFile { "LVL1Config.xml" };
string l1topoOutFile { "L1TopoConfig.xml" }; string l1topoOutFile { "L1TopoConfig.xml" };
string hltxmlOutFile { "HLTConfig.xml" }; string hltxmlOutFile { "HLTConfig.xml" };
string hltJsonOutFile { "HLTMenu.json" };
string coolInputConnection { "" }; string coolInputConnection { "" };
string coolOutputConnection { "" }; string coolOutputConnection { "" };
unsigned int coolOutputRunNr { 0 }; unsigned int coolOutputRunNr { 0 };
...@@ -210,9 +215,9 @@ JobConfig::parseProgramOptions(int argc, char* argv[]) { ...@@ -210,9 +215,9 @@ JobConfig::parseProgramOptions(int argc, char* argv[]) {
} else { } else {
if(currentPar == "i" || currentPar == "input") { inpar.push_back(stripped); continue; } if(currentPar == "i" || currentPar == "input") { inpar.push_back(stripped); continue; }
if(currentPar == "2" || currentPar == "comp") { inpar2.push_back(stripped); continue; } if(currentPar == "2" || currentPar == "comp") { inpar2.push_back(stripped); continue; }
if(currentPar == "o" || currentPar == "output") { if(currentPar == "o" || currentPar == "output") {
if(outpar.size()==0 && stripped != "xml" && stripped != "cool") { if(outpar.size()==0 && stripped != "xml" && stripped != "r3json" && stripped != "cool") {
error.push_back("Unknown output type: " + stripped + ". Must be either xml or cool, optionally followed by a base string for the output file name"); error.push_back("Unknown output type: " + stripped + ". Must be either xml, json or cool, optionally followed by a base string for the output file name");
} else { } else {
outpar.push_back(stripped); outpar.push_back(stripped);
} }
...@@ -228,7 +233,7 @@ JobConfig::parseProgramOptions(int argc, char* argv[]) { ...@@ -228,7 +233,7 @@ JobConfig::parseProgramOptions(int argc, char* argv[]) {
else if("ERROR" == stripped ) { outputlevel = MSGTC::ERROR; } else if("ERROR" == stripped ) { outputlevel = MSGTC::ERROR; }
else if("FATAL" == stripped ) { outputlevel = MSGTC::FATAL; } else if("FATAL" == stripped ) { outputlevel = MSGTC::FATAL; }
else if("ALWAYS" == stripped ) { outputlevel = MSGTC::ALWAYS; } else if("ALWAYS" == stripped ) { outputlevel = MSGTC::ALWAYS; }
else { else {
error.push_back("Unknown output level: " + stripped + ". Must be one of NIL, VERBOSE, DEBUG, INFO, WARNING, ERROR, FATAL, ALWAYS"); error.push_back("Unknown output level: " + stripped + ". Must be one of NIL, VERBOSE, DEBUG, INFO, WARNING, ERROR, FATAL, ALWAYS");
} }
continue; continue;
...@@ -242,8 +247,8 @@ JobConfig::parseProgramOptions(int argc, char* argv[]) { ...@@ -242,8 +247,8 @@ JobConfig::parseProgramOptions(int argc, char* argv[]) {
error.push_back("No input specified, use '-i' option"); error.push_back("No input specified, use '-i' option");
// parse the input // parse the input
if( (inpar.size()==1 && endswith(inpar[0],".xml")) || if( (inpar.size()==1 && endswith(inpar[0],".xml")) ||
(inpar.size()==2 && endswith(inpar[0],".xml") && endswith(inpar[1],".xml")) ) { (inpar.size()==2 && endswith(inpar[0],".xml") && endswith(inpar[1],".xml")) ) {
input = XML; input = XML;
} else if( inpar.size()>=1 && inpar[0].find(".db") != string::npos ) { } else if( inpar.size()>=1 && inpar[0].find(".db") != string::npos ) {
...@@ -276,15 +281,17 @@ JobConfig::parseProgramOptions(int argc, char* argv[]) { ...@@ -276,15 +281,17 @@ JobConfig::parseProgramOptions(int argc, char* argv[]) {
}; };
} }
if( (inpar2.size()==1 && endswith(inpar2[0],".xml")) || if( (inpar2.size()==1 && endswith(inpar2[0],".xml")) ||
(inpar2.size()==2 && endswith(inpar2[1],".xml") && endswith(inpar2[1],".xml")) ) { (inpar2.size()==2 && endswith(inpar2[1],".xml") && endswith(inpar2[1],".xml")) ) {
input2 = XML; input2 = XML;
} }
// parse the output // parse the output
for(const string& o: outpar) { for(const string& o: outpar) {
if ( o=="xml") { if ( o=="xml") {
output |= XML; output |= XML;
} else if ( o=="r3json" ) {
output |= JSON;
} else if ( o=="cool" ) { } else if ( o=="cool" ) {
output |= COOL; output |= COOL;
} else if ( isUnsignedInteger(o) ) { } else if ( isUnsignedInteger(o) ) {
...@@ -312,6 +319,7 @@ JobConfig::parseProgramOptions(int argc, char* argv[]) { ...@@ -312,6 +319,7 @@ JobConfig::parseProgramOptions(int argc, char* argv[]) {
l1xmlOutFile = "LVL1config_" + outBase + ".xml"; l1xmlOutFile = "LVL1config_" + outBase + ".xml";
l1topoOutFile = "L1TopoConfig_" + outBase + ".xml"; l1topoOutFile = "L1TopoConfig_" + outBase + ".xml";
hltxmlOutFile = "HLTconfig_" + outBase + ".xml"; hltxmlOutFile = "HLTconfig_" + outBase + ".xml";
hltJsonOutFile = "HLTMenu_" + outBase + ".json";
} }
} }
...@@ -319,17 +327,17 @@ JobConfig::parseProgramOptions(int argc, char* argv[]) { ...@@ -319,17 +327,17 @@ JobConfig::parseProgramOptions(int argc, char* argv[]) {
string JobConfig::CheckForCompleteSetup() { string JobConfig::CheckForCompleteSetup() {
if(input==UNDEF) if(input==UNDEF)
return "Use argument '-i' to specify input source and check that the input is specified correctly"; return "Use argument '-i' to specify input source and check that the input is specified correctly";
if( input == DB ) { if( input == DB ) {
if( db == "" ) if( db == "" )
return "No TriggerDB connection string specified"; return "No TriggerDB connection string specified";
if( keys.size()==0 ) if( keys.size()==0 )
return "No configuration key(s) specified"; return "No configuration key(s) specified";
} }
if( input2 == DB ) { if( input2 == DB ) {
if( db2 == "" ) if( db2 == "" )
return "No TriggerDB connection string specified for comparison, use option '--db2'"; return "No TriggerDB connection string specified for comparison, use option '--db2'";
if( keys2.size()==0 ) if( keys2.size()==0 )
return "No smk specified for comparison, use option '--dbsmk2'"; return "No smk specified for comparison, use option '--dbsmk2'";
} }
...@@ -356,7 +364,7 @@ JobConfig::PrintSetup(std::ostream & log, std::ostream& (*lineend) ( std::ostrea ...@@ -356,7 +364,7 @@ JobConfig::PrintSetup(std::ostream & log, std::ostream& (*lineend) ( std::ostrea
if( output != UNDEF ) { if( output != UNDEF ) {
log << " Output : "; log << " Output : ";
if( output&XML ) log << l1xmlOutFile << ", " << l1topoOutFile << ", " << hltxmlOutFile; if( output&XML ) log << l1xmlOutFile << ", " << l1topoOutFile << ", " << hltxmlOutFile;
if( output&COOL ) { if( output&COOL ) {
log << coolOutputConnection; log << coolOutputConnection;
if(coolOutputRunNr==0) { log << ", infinite IOV"; } else { log << ", run nr " << coolOutputRunNr; } if(coolOutputRunNr==0) { log << ", infinite IOV"; } else { log << ", run nr " << coolOutputRunNr; }
} }
...@@ -370,7 +378,7 @@ JobConfig::PrintSetup(std::ostream & log, std::ostream& (*lineend) ( std::ostrea ...@@ -370,7 +378,7 @@ JobConfig::PrintSetup(std::ostream & log, std::ostream& (*lineend) ( std::ostrea
int main( int argc, char* argv[] ) { int main( int argc, char* argv[] ) {
/*************************************** /***************************************
* *
* Getting the program parameters * Getting the program parameters
...@@ -407,9 +415,9 @@ int main( int argc, char* argv[] ) { ...@@ -407,9 +415,9 @@ int main( int argc, char* argv[] ) {
if(errf) errf->close(); if(errf) errf->close();
return 1; return 1;
} }
gConfig.PrintSetup(log, lineend); gConfig.PrintSetup(log, lineend);
/*************************************** /***************************************
* *
...@@ -421,7 +429,7 @@ int main( int argc, char* argv[] ) { ...@@ -421,7 +429,7 @@ int main( int argc, char* argv[] ) {
HLTFrame* hltFrame(0); HLTFrame* hltFrame(0);
TXC::L1TopoMenu* l1tm = nullptr; TXC::L1TopoMenu* l1tm = nullptr;
uint smk(0),l1psk(0),hltpsk(0),bgsk(0), mck{0}; uint smk(0),l1psk(0),hltpsk(0),bgsk(0), mck{0};
string release; string release;
/*------------------ /*------------------
...@@ -430,7 +438,7 @@ int main( int argc, char* argv[] ) { ...@@ -430,7 +438,7 @@ int main( int argc, char* argv[] ) {
if (gConfig.input == JobConfig::DB) { if (gConfig.input == JobConfig::DB) {
unique_ptr<StorageMgr> sm(new StorageMgr(gConfig.db, "", "", log)); unique_ptr<StorageMgr> sm(new StorageMgr(gConfig.db, "", "", log));
// Loading L1 topo // Loading L1 topo
//log << "Retrieving Lvl1 Topo configuration" << lineend; //log << "Retrieving Lvl1 Topo configuration" << lineend;
l1tm = new TXC::L1TopoMenu(); l1tm = new TXC::L1TopoMenu();
l1tm->setSMK(gConfig.getKey(0)); l1tm->setSMK(gConfig.getKey(0));
...@@ -469,9 +477,9 @@ int main( int argc, char* argv[] ) { ...@@ -469,9 +477,9 @@ int main( int argc, char* argv[] ) {
mckloader->loadReleaseLinkedToMCK(mck,release); mckloader->loadReleaseLinkedToMCK(mck,release);
log << "Loaded MCK " << mck << " (active for SMK " << smk << " and release " << release << ")" << endl; log << "Loaded MCK " << mck << " (active for SMK " << smk << " and release " << release << ")" << endl;
} else { } else {
log << "Did not load MCK from DB as MCK is 0 or no MCK is linked"; log << "Did not load MCK from DB as MCK is 0 or no MCK is linked";
} }
} }
/*------------------ /*------------------
...@@ -522,7 +530,7 @@ int main( int argc, char* argv[] ) { ...@@ -522,7 +530,7 @@ int main( int argc, char* argv[] ) {
PrescaleSet ps; PrescaleSet ps;
coolWriter->readL1PrescalePayload( runnumber, lb, l1psk, ps); coolWriter->readL1PrescalePayload( runnumber, lb, l1psk, ps);
ctpc->setPrescaleSet( ps ); ctpc->setPrescaleSet( ps );
// log << "L1 PSK 0 " << ps.id() << lineend; // log << "L1 PSK 0 " << ps.id() << lineend;
// log << "L1 PSK 1 " << l1psk << lineend; // log << "L1 PSK 1 " << l1psk << lineend;
// log << "L1 PSK 2 " << ctpc->prescaleSet().id() << lineend; // log << "L1 PSK 2 " << ctpc->prescaleSet().id() << lineend;
...@@ -561,7 +569,7 @@ int main( int argc, char* argv[] ) { ...@@ -561,7 +569,7 @@ int main( int argc, char* argv[] ) {
if (gConfig.input2 != JobConfig::UNDEF) { if (gConfig.input2 != JobConfig::UNDEF) {
CTPConfig* ctpc2(0); CTPConfig* ctpc2(0);
HLTFrame* hltFrame2(0); HLTFrame* hltFrame2(0);
/*------------------ /*------------------
* from DB * from DB
*-----------------*/ *-----------------*/
...@@ -578,7 +586,7 @@ int main( int argc, char* argv[] ) { ...@@ -578,7 +586,7 @@ int main( int argc, char* argv[] ) {
sm->masterTableLoader().load(*ctpc2); sm->masterTableLoader().load(*ctpc2);
ctpc2->muCTPi().setSMK( gConfig.getKey2(0) ); ctpc2->muCTPi().setSMK( gConfig.getKey2(0) );
sm->masterTableLoader().load(ctpc2->muCTPi()); sm->masterTableLoader().load(ctpc2->muCTPi());
log << "Retrieving HLT menu configuration and prescale set from the TriggerDB for comparison" << lineend; log << "Retrieving HLT menu configuration and prescale set from the TriggerDB for comparison" << lineend;
hltFrame2 = new HLTFrame(); hltFrame2 = new HLTFrame();
hltFrame2->setSMK( gConfig.getKey2(0) ); hltFrame2->setSMK( gConfig.getKey2(0) );
...@@ -594,7 +602,7 @@ int main( int argc, char* argv[] ) { ...@@ -594,7 +602,7 @@ int main( int argc, char* argv[] ) {
unique_ptr<XMLStorageMgr> sm( gConfig.inpar2.size()==1 ? unique_ptr<XMLStorageMgr> sm( gConfig.inpar2.size()==1 ?
new XMLStorageMgr( { xmlpathresolve(gConfig.inpar2[0]) } ) : new XMLStorageMgr( { xmlpathresolve(gConfig.inpar2[0]) } ) :
new XMLStorageMgr( { xmlpathresolve(gConfig.inpar2[0]),xmlpathresolve(gConfig.inpar2[1]) } ) ); new XMLStorageMgr( { xmlpathresolve(gConfig.inpar2[0]),xmlpathresolve(gConfig.inpar2[1]) } ) );
if(sm->hasLVL1()) { if(sm->hasLVL1()) {
ctpc2 = new CTPConfig(); ctpc2 = new CTPConfig();
log << "Retrieving Lvl1 CTP configuration from " << sm->m_xmlL1File << lineend; log << "Retrieving Lvl1 CTP configuration from " << sm->m_xmlL1File << lineend;
...@@ -611,7 +619,7 @@ int main( int argc, char* argv[] ) { ...@@ -611,7 +619,7 @@ int main( int argc, char* argv[] ) {
sm->hltFrameLoader().load( *hltFrame2 ); sm->hltFrameLoader().load( *hltFrame2 );
log << "Done reading " << sm->m_xmlHLTFile << lineend; log << "Done reading " << sm->m_xmlHLTFile << lineend;
} }
} else if (gConfig.input2 == JobConfig::COOL) { } else if (gConfig.input2 == JobConfig::COOL) {
/*------------------ /*------------------
* from COOL * from COOL
...@@ -665,6 +673,17 @@ int main( int argc, char* argv[] ) { ...@@ -665,6 +673,17 @@ int main( int argc, char* argv[] ) {
} }
} }
if ( (gConfig.output & JobConfig::JSON) != 0 ) {
/*------------------
* to JSON
*-----------------*/
// TODO add L1 menu
if(hltFrame) {
convertRun2HLTtoRun3(hltFrame, gConfig.hltJsonOutFile);
}
}
if ( (gConfig.output & JobConfig::COOL) != 0 ) { if ( (gConfig.output & JobConfig::COOL) != 0 ) {
/*------------------ /*------------------
* to COOL * to COOL
...@@ -677,16 +696,16 @@ int main( int argc, char* argv[] ) { ...@@ -677,16 +696,16 @@ int main( int argc, char* argv[] ) {
string info(""); string info("");
unsigned int runNr = gConfig.coolOutputRunNr; unsigned int runNr = gConfig.coolOutputRunNr;
if(runNr == 0) { runNr = 0x80000000; } // infinite range if(runNr == 0) { runNr = 0x80000000; } // infinite range
if(ctpc) if(ctpc)
coolWriter->writeL1Payload(runNr, *ctpc); coolWriter->writeL1Payload(runNr, *ctpc);
try{ try{
if(hltFrame) if(hltFrame)
coolWriter->writeHLTPayload(runNr, *hltFrame, configSource); coolWriter->writeHLTPayload(runNr, *hltFrame, configSource);
} }
catch(const cool::StorageTypeStringTooLong& e){ catch(const cool::StorageTypeStringTooLong& e){
log << "FATAL: Unable to write data to COOL"; log << "FATAL: Unable to write data to COOL";
exit(1); exit(1);
} }
if(mck) if(mck)
coolWriter->writeMCKPayload(runNr, mck, release, info); coolWriter->writeMCKPayload(runNr, mck, release, info);
...@@ -696,12 +715,12 @@ int main( int argc, char* argv[] ) { ...@@ -696,12 +715,12 @@ int main( int argc, char* argv[] ) {
delete hltFrame; delete hltFrame;
if(l1tm!=nullptr) if(l1tm!=nullptr)
delete l1tm; delete l1tm;
if( gConfig.jo ) { if( gConfig.jo ) {
JobOptionTable jot; JobOptionTable jot;
unique_ptr<IStorageMgr> sm( new StorageMgr(gConfig.db,"","",log) ); unique_ptr<IStorageMgr> sm( new StorageMgr(gConfig.db,"","",log) );
log << "TrigConfReadWrite: Retrieving JO from the TriggerDB" << lineend; log << "TrigConfReadWrite: Retrieving JO from the TriggerDB" << lineend;
jot.setSMK( gConfig.getKey(0) ); jot.setSMK( gConfig.getKey(0) );
jot.setTriggerLevel(0); // L2 jot.setTriggerLevel(0); // L2
...@@ -715,4 +734,3 @@ int main( int argc, char* argv[] ) { ...@@ -715,4 +734,3 @@ int main( int argc, char* argv[] ) {
} }
} }
Trigger/TrigConfiguration/TrigConfStorage/src/test/Run2toRun3Converters.cxx 0 → 100644
+ 120
− 0
View file @ d7bf3442
#include "TrigConfData/HLTMenu.h"
#include "TrigConfData/DataStructure.h"
#include "TrigCompositeUtils/HLTIdentifier.h"
#include <boost/property_tree/json_parser.hpp>
#include "TrigConfHLTData/HLTFrame.h"
#include "TrigConfHLTData/HLTChain.h"
#include "TrigConfHLTData/HLTStreamTag.h"
#include "TrigConfHLTData/HLTSignature.h"
#include "TrigConfHLTData/HLTTriggerElement.h"
#include "TrigConfIO/JsonFileWriterHLT.h"
template<typename COLL>
boost::property_tree::ptree asArray( const COLL& data) {
using ptree = boost::property_tree::ptree;
ptree array;
for ( const auto& el: data ) {
ptree one;
one.put("", el);
array.push_back(std::make_pair("", one));
}
return array;
}
std::vector<int> legMult(const TrigConf::HLTChain* cptr) {
std::vector<int> maxMult;
for ( const auto sig: cptr->signatures() ) {
std::vector<std::string> names;
std::vector<int> mult;
for ( const auto te: sig->outputTEs() ) {
auto found = std::find(names.begin(), names.end(), te->name());
if ( found == names.end() ) {
names.push_back(te->name());
mult.push_back(1);
} else {
int index = std::find(names.begin(), names.end(), te->name()) - names.begin();
mult[index]++;
}
}
if ( maxMult.size() < mult.size() ) {
maxMult = mult;
}
}
return maxMult;
}
std::vector<std::string> l1thresholds(const TrigConf::HLTFrame* frame, const TrigConf::HLTChain* cptr) {
std::set<std::string> names;
for ( const auto sig: cptr->signatures() ) {
for ( const auto te: sig->outputTEs() ) {
auto sequence = frame->sequences().getSequence(te->name());
for ( const auto inTE: sequence->inputTEs() ) {
std::cout << "IN TE" << inTE->name() << " \n";
if ( not ( inTE->name().find("L2_") == 0 or inTE->name().find("EF_") == 0 or inTE->name().find("HLT_") == 0 ) ) {
names.insert(inTE->name());
std::cout << "L1 is " << inTE->name() << " \n";
}
}
}
}
return std::vector<std::string>( names.begin(), names.end() );
}
void convertRun2HLTtoRun3(const TrigConf::HLTFrame* frame, const std::string& filename) {
using ptree = boost::property_tree::ptree;
ptree top;
top.put("filetype", "hltmenu");
top.put("name", frame->name());
ptree pChains;
std::map<std::string, const TrigConf::HLTStreamTag*> allStreams;
for ( auto cptr : frame->chains() ) {
ptree pChain;
pChain.put("counter", cptr->chain_counter());
pChain.put("nameHash", cptr->chain_hash_id());
pChain.put("l1item", cptr->lower_chain_name());
pChain.add_child("l1thresholds", asArray(l1thresholds(frame, cptr)));
pChain.add_child("legMultiplicities", asArray(legMult(cptr)) );
pChain.add_child("sequencers", asArray(std::vector<std::string>({"missing"})));
std::vector<std::string> strNames;
for ( const auto st: cptr->streams()) {
strNames.push_back(st->stream());
allStreams[st->stream()] = st;
}
pChain.add_child("streams", asArray(strNames));
pChain.add_child("groups", asArray(cptr->groups()));
pChains.push_back(std::make_pair(cptr->chain_name(), pChain));
}
ptree pStreams;
for ( auto [sname, stream]: allStreams ) {
ptree pStream;
pStream.put("name", sname);
pStream.put("type", stream->type());
pStream.put("obeyLB", stream->obeyLB());
pStream.put("forceFullEventBuilding", true); // TODO understand how to get this information from old menu
pStreams.push_back(std::make_pair(sname, pStream));
}
top.add_child("chains", pChains);
top.add_child("streams", pStreams);
ptree pSequencers;
pSequencers.add_child("missing", asArray(std::vector<std::string>({""})));
top.add_child("sequencers", pSequencers);
std::stringstream ss;
boost::property_tree::json_parser::write_json(ss, top);
// std::cout << ss.str() << std::endl;
TrigConf::HLTMenu menu(std::move(top));
TrigConf::JsonFileWriterHLT writer;
std::cout << "Saving file: " << filename << std::endl;
writer.writeJsonFile(filename, menu);
}
\ No newline at end of file
Trigger/TrigConfiguration/TrigConfStorage/src/test/Run2toRun3Converters.h 0 → 100644
+ 7
− 0
View file @ d7bf3442
/*
Copyright (C) 2002-2020 CERN for the benefit of the ATLAS collaboration
*/
#include "TrigConfData/HLTMenu.h"
#include "TrigConfHLTData/HLTFrame.h"
void convertRun2HLTtoRun3(const TrigConf::HLTFrame* frame, const std::string& filename);
\ No newline at end of file
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment