Skip to content

Commit fbcb41d

Browse files
BarthelemyBarthelemy
authored
Fix formatting (#218)
1 parent 1e34936 commit fbcb41d

10 files changed

Lines changed: 44 additions & 42 deletions

File tree

‎Framework/include/QualityControl/TaskRunnerFactory.h‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ class TaskRunnerFactory
3636
/// \param id - subSpecification for taskRunner's OutputSpec, useful to avoid outputs collisions one more complex topologies
3737
/// \param resetAfterPublish - should taskRunner reset the user's task after each MO publication
3838
o2::framework::DataProcessorSpec
39-
create(std::string taskName, std::string configurationSource, size_t id = 0, bool resetAfterPublish = false);
39+
create(std::string taskName, std::string configurationSource, size_t id = 0, bool resetAfterPublish = false);
4040

4141
/// \brief Provides necessary customization of the TaskRunners.
4242
///

‎Framework/src/InformationService.cxx‎

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -71,10 +71,11 @@ bool InformationService::handleRequestData(FairMQMessagePtr& request, int /*inde
7171

7272
LOG(INFO) << "Sending reply to client.";
7373
FairMQMessagePtr reply(
74-
NewMessage(const_cast<char*>(result->c_str()), // data
75-
result->length(), // size
76-
[](void* /*data*/, void* object) { delete static_cast<string*>(object); }, // deletion callback
77-
result)); // object that manages the data
74+
NewMessage(
75+
const_cast<char*>(result->c_str()), // data
76+
result->length(), // size
77+
[](void* /*data*/, void* object) { delete static_cast<string*>(object); }, // deletion callback
78+
result)); // object that manages the data
7879
if (Send(reply, "request_data") <= 0) {
7980
LOG(ERROR) << "error sending reply";
8081
}
@@ -208,8 +209,9 @@ std::string InformationService::produceJsonAll()
208209

209210
void InformationService::sendJson(std::string* json)
210211
{
211-
FairMQMessagePtr msg2(NewMessage(const_cast<char*>(json->c_str()), json->length(),
212-
[](void* /*data*/, void* object) { delete static_cast<string*>(object); }, json));
212+
FairMQMessagePtr msg2(NewMessage(
213+
const_cast<char*>(json->c_str()), json->length(),
214+
[](void* /*data*/, void* object) { delete static_cast<string*>(object); }, json));
213215
int ret = Send(msg2, "updates_output");
214216
if (ret < 0) {
215217
LOG(ERROR) << "Error sending update";

‎Framework/src/InformationServiceDump.cxx‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -39,10 +39,11 @@ bool InformationServiceDump::HandleData(FairMQMessagePtr& msg, int /*index*/)
3939
string* text = new string(fConfig->GetValue<string>("request-task"));
4040
LOG(INFO) << "Preparing request for \"" << *text << "\"";
4141
FairMQMessagePtr request(
42-
NewMessage(const_cast<char*>(text->c_str()), // data
43-
text->length(), // size
44-
[](void* /*data*/, void* object) { delete static_cast<string*>(object); }, // deletion callback
45-
text)); // object that manages the data
42+
NewMessage(
43+
const_cast<char*>(text->c_str()), // data
44+
text->length(), // size
45+
[](void* /*data*/, void* object) { delete static_cast<string*>(object); }, // deletion callback
46+
text)); // object that manages the data
4647
LOG(INFO) << "Sending request ";
4748
if (Send(request, "send_request") > 0) {
4849
FairMQMessagePtr reply(NewMessage());

‎Framework/src/InfrastructureGenerator.cxx‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,6 @@ void InfrastructureGenerator::generateLocalInfrastructure(framework::WorkflowSpe
6161
workflow.insert(std::end(workflow), std::begin(qcInfrastructure), std::end(qcInfrastructure));
6262
}
6363

64-
6564
o2::framework::WorkflowSpec InfrastructureGenerator::generateRemoteInfrastructure(std::string configurationSource)
6665
{
6766
WorkflowSpec workflow;

‎Framework/src/RepositoryBenchmark.h‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ class RepositoryBenchmark : public FairMQDevice
5757
// internal state
5858
std::unique_ptr<o2::quality_control::repository::DatabaseInterface> mDatabase;
5959
std::vector<std::shared_ptr<MonitorObject>> mMyObjects;
60-
// TH1* mMyHisto;
60+
// TH1* mMyHisto;
6161

6262
// variables for the timer
6363
boost::asio::deadline_timer* mTimer; /// the asynchronous timer to send monitoring data

‎Framework/src/TaskRunnerFactory.cxx‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ namespace o2::quality_control::core
2323
using namespace o2::framework;
2424

2525
o2::framework::DataProcessorSpec
26-
TaskRunnerFactory::create(std::string taskName, std::string configurationSource, size_t id, bool resetAfterPublish)
26+
TaskRunnerFactory::create(std::string taskName, std::string configurationSource, size_t id, bool resetAfterPublish)
2727
{
2828
TaskRunner qcTask{ taskName, configurationSource, id };
2929
qcTask.setResetAfterPublish(resetAfterPublish);

‎Framework/test/testCcdbDatabase.cxx‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,6 @@ BOOST_AUTO_TEST_CASE(ccdb_create)
6565
test_fixture f;
6666

6767
f.backend->truncate("my/task", "*");
68-
6968
}
7069

7170
BOOST_AUTO_TEST_CASE(ccdb_getobjects_name)

‎Modules/Daq/test/testQcDaq.cxx‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -28,20 +28,20 @@ BOOST_AUTO_TEST_CASE(instantiate_task)
2828
// o2::framework::InitContext ctx;
2929
// task.initialize(ctx); // TODO
3030

31-
// BOOST_CHECK(manager->getMonitorObject("payloadSize")->getObject() != nullptr);
31+
// BOOST_CHECK(manager->getMonitorObject("payloadSize")->getObject() != nullptr);
3232

33-
// Activity activity;
34-
// task.startOfActivity(activity);
35-
// task.startOfCycle();
33+
// Activity activity;
34+
// task.startOfActivity(activity);
35+
// task.startOfCycle();
3636
// auto producer = AliceO2::DataSampling::DataBlockProducer(false, 1024);
3737
// DataSetReference dataSet = producer.getDataSet();
3838
// task.monitorDataBlock(dataSet);// TODO
3939

40-
// TH1F* histo = (TH1F*)manager->getMonitorObject("payloadSize")->getObject();
41-
// BOOST_CHECK(histo->GetEntries() == 1);
40+
// TH1F* histo = (TH1F*)manager->getMonitorObject("payloadSize")->getObject();
41+
// BOOST_CHECK(histo->GetEntries() == 1);
4242

43-
// task.endOfCycle();
44-
// task.endOfActivity(activity);
43+
// task.endOfCycle();
44+
// task.endOfActivity(activity);
4545
}
4646

4747
} // namespace o2::quality_control_modules::daq

‎Modules/Example/test/testQcExample.cxx‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -28,23 +28,23 @@ BOOST_AUTO_TEST_CASE(insantiate_task)
2828
task.setObjectsManager(manager);
2929
// task.initialize();// TODO
3030

31-
// BOOST_CHECK(task.getHisto1() != nullptr);
32-
// BOOST_CHECK(task.getHisto2() != nullptr);
31+
// BOOST_CHECK(task.getHisto1() != nullptr);
32+
// BOOST_CHECK(task.getHisto2() != nullptr);
3333

3434
Activity activity;
3535
task.startOfActivity(activity);
36-
// task.startOfCycle();
36+
// task.startOfCycle();
3737
// auto producer = AliceO2::DataSampling::DataBlockProducer(false, 1024);
3838
// DataSetReference dataSet = producer.getDataSet();
3939
// task.monitorDataBlock(dataSet);// TODO
4040

41-
// BOOST_CHECK(task.getHisto1()->GetEntries() > 0);
41+
// BOOST_CHECK(task.getHisto1()->GetEntries() > 0);
4242

43-
// task.endOfCycle();
43+
// task.endOfCycle();
4444
task.endOfActivity(activity);
4545
task.startOfActivity(activity);
4646

47-
// BOOST_CHECK(task.getHisto1()->GetEntries() == 0);
47+
// BOOST_CHECK(task.getHisto1()->GetEntries() == 0);
4848

4949
task.endOfActivity(activity);
5050
}

‎Modules/Skeleton/src/SkeletonTask.cxx‎

Lines changed: 14 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,8 @@ namespace o2::quality_control_modules::skeleton
2525

2626
SkeletonTask::SkeletonTask() : TaskInterface(), mHistogram(nullptr) { mHistogram = nullptr; }
2727

28-
SkeletonTask::~SkeletonTask() {
28+
SkeletonTask::~SkeletonTask()
29+
{
2930
if (mHistogram) {
3031
delete mHistogram;
3132
}
@@ -86,22 +87,22 @@ void SkeletonTask::monitorData(o2::framework::ProcessingContext& ctx)
8687
// 2. Using get("<binding>")
8788

8889
// get the payload of a specific input, which is a char array. "random" is the binding specified in the config file.
89-
// auto payload = ctx.inputs().get("random").payload;
90+
// auto payload = ctx.inputs().get("random").payload;
9091

9192
// get payload of a specific input, which is a structure array:
92-
// const auto* header = header::get<header::DataHeader*>(ctx.inputs().get("random").header);
93-
// struct s {int a; double b;};
94-
// auto array = ctx.inputs().get<s*>("random");
95-
// for (int j = 0; j < header->payloadSize / sizeof(s); ++j) {
96-
// int i = array.get()[j].a;
97-
// }
93+
// const auto* header = header::get<header::DataHeader*>(ctx.inputs().get("random").header);
94+
// struct s {int a; double b;};
95+
// auto array = ctx.inputs().get<s*>("random");
96+
// for (int j = 0; j < header->payloadSize / sizeof(s); ++j) {
97+
// int i = array.get()[j].a;
98+
// }
9899

99100
// get payload of a specific input, which is a root object
100-
// auto h = ctx.inputs().get<TH1F*>("histos");
101-
// Double_t stats[4];
102-
// h->GetStats(stats);
103-
// auto s = ctx.inputs().get<TObjString*>("string");
104-
// LOG(INFO) << "String is " << s->GetString().Data();
101+
// auto h = ctx.inputs().get<TH1F*>("histos");
102+
// Double_t stats[4];
103+
// h->GetStats(stats);
104+
// auto s = ctx.inputs().get<TObjString*>("string");
105+
// LOG(INFO) << "String is " << s->GetString().Data();
105106
}
106107

107108
void SkeletonTask::endOfCycle()

0 commit comments

Comments
 (0)