Skip to content

Commit 18f954a

Browse files
awegrzynBarthelemy
authored andcommitted
Adpot to new Configuration
1 parent 8ad3185 commit 18f954a

5 files changed

Lines changed: 25 additions & 25 deletions

File tree

‎Framework/src/CcdbDatabase.cxx‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ void CcdbDatabase::connect(std::string host, std::string database, std::string u
4343

4444
void CcdbDatabase::connect(std::unique_ptr<ConfigurationInterface>& config)
4545
{
46-
mUrl = config->get<string>("qc/config/database/host").value();
46+
mUrl = config->get<string>("qc/config/database/host");
4747
ccdbApi.init(mUrl);
4848
}
4949

@@ -185,4 +185,4 @@ void CcdbDatabase::truncate(std::string taskName, std::string objectName)
185185

186186
} // namespace repository
187187
} // namespace quality_control
188-
} // namespace o2
188+
} // namespace o2

‎Framework/src/Checker.cxx‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ void Checker::init(framework::InitContext&)
6666
try {
6767
std::unique_ptr<ConfigurationInterface> config = ConfigurationFactory::getConfiguration(mConfigurationSource);
6868
// configuration of the database
69-
mDatabase = DatabaseFactory::create(config->get<std::string>("qc/config/database/implementation").value());
69+
mDatabase = DatabaseFactory::create(config->get<std::string>("qc/config/database/implementation"));
7070
mDatabase->connect(config);
7171
} catch (
7272
std::string const& e) { // we have to catch here to print the exception because the device will make it disappear

‎Framework/src/MySqlDatabase.cxx‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -59,10 +59,10 @@ void MySqlDatabase::connect(std::string host, std::string database, std::string
5959

6060
void MySqlDatabase::connect(std::unique_ptr<ConfigurationInterface>& config)
6161
{
62-
this->connect(config->get<string>("qc/config/database/host").value(),
63-
config->get<string>("qc/config/database/name").value(),
64-
config->get<string>("qc/config/database/username").value(),
65-
config->get<string>("qc/config/database/password").value());
62+
this->connect(config->get<string>("qc/config/database/host"),
63+
config->get<string>("qc/config/database/name"),
64+
config->get<string>("qc/config/database/username"),
65+
config->get<string>("qc/config/database/password"));
6666
}
6767

6868
void MySqlDatabase::prepareTaskDataContainer(std::string taskName)

‎Framework/src/TaskRunner.cxx‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -142,25 +142,25 @@ void TaskRunner::populateConfig(std::string taskName)
142142
{
143143
try {
144144
std::string prefix = std::string("qc/tasks_config/");
145-
std::string taskDefinitionName = mConfigFile->get<std::string>(prefix + taskName + "/taskDefinition").value();
145+
std::string taskDefinitionName = mConfigFile->get<std::string>(prefix + taskName + "/taskDefinition");
146146

147147
mTaskConfig.taskName = taskName;
148-
mTaskConfig.moduleName = mConfigFile->get<std::string>(prefix + taskDefinitionName + "/moduleName").value();
149-
mTaskConfig.className = mConfigFile->get<std::string>(prefix + taskDefinitionName + "/className").value();
148+
mTaskConfig.moduleName = mConfigFile->get<std::string>(prefix + taskDefinitionName + "/moduleName");
149+
mTaskConfig.className = mConfigFile->get<std::string>(prefix + taskDefinitionName + "/className");
150150
mTaskConfig.cycleDurationSeconds =
151-
mConfigFile->get<int>(prefix + taskDefinitionName + "/cycleDurationSeconds").value_or(10);
152-
mTaskConfig.maxNumberCycles = mConfigFile->get<int>(prefix + taskDefinitionName + "/maxNumberCycles").value_or(-1);
151+
mConfigFile->get<int>(prefix + taskDefinitionName + "/cycleDurationSeconds", 10);
152+
mTaskConfig.maxNumberCycles = mConfigFile->get<int>(prefix + taskDefinitionName + "/maxNumberCycles", -1);
153153

154154
// maybe it should be moved somewhere else?
155-
std::string taskInputsNames = mConfigFile->getString(prefix + taskDefinitionName + "/inputs").value();
155+
std::string taskInputsNames = mConfigFile->get<std::string>(prefix + taskDefinitionName + "/inputs");
156156
std::vector<std::string> taskInputsSplit;
157157
boost::split(taskInputsSplit, taskInputsNames, boost::is_any_of(","));
158158

159159
for (auto&& input : taskInputsSplit) {
160160
InputSpec inputSpec;
161-
inputSpec.binding = mConfigFile->getString(prefix + input + "/inputName").value();
162-
inputSpec.origin.runtimeInit(mConfigFile->getString(prefix + input + "/dataOrigin").value().c_str());
163-
inputSpec.description.runtimeInit(mConfigFile->getString(prefix + input + "/dataDescription").value().c_str());
161+
inputSpec.binding = mConfigFile->get<std::string>(prefix + input + "/inputName");
162+
inputSpec.origin.runtimeInit(mConfigFile->get<std::string>(prefix + input + "/dataOrigin").c_str());
163+
inputSpec.description.runtimeInit(mConfigFile->get<std::string>(prefix + input + "/dataDescription").c_str());
164164
size_t len = strlen(inputSpec.description.str);
165165
if (len < inputSpec.description.size - 2) {
166166
inputSpec.description.str[len] = '_';
@@ -189,15 +189,15 @@ void TaskRunner::populateConfig(std::string taskName)
189189
void TaskRunner::startOfActivity()
190190
{
191191
mTimerTotalDurationActivity.reset();
192-
Activity activity(mConfigFile->get<int>("qc/config/Activity/number").value(),
193-
mConfigFile->get<int>("qc/config/Activity/type").value());
192+
Activity activity(mConfigFile->get<int>("qc/config/Activity/number"),
193+
mConfigFile->get<int>("qc/config/Activity/type"));
194194
mTask->startOfActivity(activity);
195195
}
196196

197197
void TaskRunner::endOfActivity()
198198
{
199-
Activity activity(mConfigFile->get<int>("qc/config/Activity/number").value(),
200-
mConfigFile->get<int>("qc/config/Activity/type").value());
199+
Activity activity(mConfigFile->get<int>("qc/config/Activity/number"),
200+
mConfigFile->get<int>("qc/config/Activity/type"));
201201
mTask->endOfActivity(activity);
202202

203203
double rate = mTotalNumberObjectsPublished / mTimerTotalDurationActivity.getTime();

‎Modules/Example/src/BenchmarkTask.cxx‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -30,11 +30,11 @@ void BenchmarkTask::initialize(o2::framework::InitContext& ctx)
3030

3131
mConfigFile = ConfigurationFactory::getConfiguration("file:./example.ini");
3232
string prefix = "/qc/tasks_config/" + getName();
33-
string taskDefinitionName = mConfigFile->get<std::string>(prefix + ".taskDefinition").value();
34-
mNumberHistos = mConfigFile->get<int>(taskDefinitionName + ".numberHistos").value();
35-
mNumberChecks = mConfigFile->get<int>(taskDefinitionName + ".numberChecks").value();
36-
mTypeOfChecks = mConfigFile->get<std::string>(taskDefinitionName + ".typeOfChecks").value();
37-
mModuleOfChecks = mConfigFile->get<std::string>(taskDefinitionName + ".moduleOfChecks").value();
33+
string taskDefinitionName = mConfigFile->get<std::string>(prefix + ".taskDefinition");
34+
mNumberHistos = mConfigFile->get<int>(taskDefinitionName + ".numberHistos");
35+
mNumberChecks = mConfigFile->get<int>(taskDefinitionName + ".numberChecks");
36+
mTypeOfChecks = mConfigFile->get<std::string>(taskDefinitionName + ".typeOfChecks");
37+
mModuleOfChecks = mConfigFile->get<std::string>(taskDefinitionName + ".moduleOfChecks");
3838

3939
mHistos.reserve(mNumberHistos);
4040

0 commit comments

Comments
 (0)