diff --git a/Framework/AnalysisSupport/src/AODReaderHelpers.cxx b/Framework/AnalysisSupport/src/AODReaderHelpers.cxx index fe3868b0b6d6e..4c1c065000186 100644 --- a/Framework/AnalysisSupport/src/AODReaderHelpers.cxx +++ b/Framework/AnalysisSupport/src/AODReaderHelpers.cxx @@ -59,7 +59,7 @@ struct Buildable { outputSchema = std::make_shared([](std::vector const& recs) { std::vector> fields; fields.reserve(recs.size()); - std::ranges::transform(recs, std::back_inserter(fields), [](auto& r){ return r.field(); }); + std::ranges::transform(recs, std::back_inserter(fields), [](auto& r) { return r.field(); }); return fields; }(records)) ->WithMetadata(std::make_shared(std::vector{std::string{"label"}}, std::vector{std::string{binding}})); @@ -88,10 +88,10 @@ AlgorithmSpec AODReaderHelpers::indexBuilderCallback(ConfigContext const& /*ctx* auto const& requested = ic.services().get().requestedIDXs; std::vector builders; builders.reserve(requested.size()); - std::ranges::transform(requested, std::back_inserter(builders), [](auto const& i){ return Buildable{i}.createBuilder(); }); + std::ranges::transform(requested, std::back_inserter(builders), [](auto const& i) { return Buildable{i}.createBuilder(); }); return [builders](ProcessingContext& pc) mutable { auto outputs = pc.outputs(); - std::ranges::for_each(builders, [&pc, &outputs](auto& builder){ outputs.adopt(Output{builder.origin, builder.description, builder.version}, builder.materialize(pc)); }); + std::ranges::for_each(builders, [&pc, &outputs](auto& builder) { outputs.adopt(Output{builder.origin, builder.description, builder.version}, builder.materialize(pc)); }); }; }}; } @@ -140,14 +140,13 @@ struct Spawnable { views::filter_string_params_starts_with("input:") | std::ranges::views::transform( [](auto const& param) { - return DataSpecUtils::fromMetadataString(param.defaultValue.template get()); - }), - std::back_inserter(matchers), [](auto const& i){ return std::get(i.matcher); }); - + return DataSpecUtils::fromMetadataString(param.defaultValue.template get()); + }), + std::back_inserter(matchers), [](auto const& i) { return std::get(i.matcher); }); std::vector> fields; std::ranges::for_each(schemas, - [&fields](auto const& s){ + [&fields](auto const& s) { std::ranges::copy(s->fields(), std::back_inserter(fields)); }); @@ -192,10 +191,10 @@ AlgorithmSpec AODReaderHelpers::aodSpawnerCallback(ConfigContext const& /*ctx*/) auto const& requested = ic.services().get().spawnerInputs; std::vector spawners; spawners.reserve(requested.size()); - std::ranges::transform(requested, std::back_inserter(spawners), [](auto const& i){ return Spawnable{i}.createMaker(); }); + std::ranges::transform(requested, std::back_inserter(spawners), [](auto const& i) { return Spawnable{i}.createMaker(); }); return [spawners](ProcessingContext& pc) mutable { auto outputs = pc.outputs(); - std::ranges::for_each(spawners, [&pc, &outputs](auto& spawner){ outputs.adopt(Output{spawner.origin, spawner.description, spawner.version}, spawner.materialize(pc)); }); + std::ranges::for_each(spawners, [&pc, &outputs](auto& spawner) { outputs.adopt(Output{spawner.origin, spawner.description, spawner.version}, spawner.materialize(pc)); }); }; }}; } diff --git a/Framework/Core/src/ASoA.cxx b/Framework/Core/src/ASoA.cxx index 9e11106fae838..1c73b257f81e4 100644 --- a/Framework/Core/src/ASoA.cxx +++ b/Framework/Core/src/ASoA.cxx @@ -63,9 +63,9 @@ SelectionVector sliceSelection(std::span const& mSelectedRows, in auto stop_iterator = std::lower_bound(start_iterator, mSelectedRows.end(), end); SelectionVector slicedSelection{start_iterator, stop_iterator}; std::ranges::transform(slicedSelection.begin(), slicedSelection.end(), slicedSelection.begin(), - [&start](int64_t idx) { - return idx - static_cast(start); - }); + [&start](int64_t idx) { + return idx - static_cast(start); + }); return slicedSelection; } @@ -74,7 +74,7 @@ std::shared_ptr ArrowHelpers::joinTables(std::vector> fields; std::vector> columns; bool notEmpty = (tables[0]->num_rows() != 0); - std::ranges::for_each(tables, [&fields, &columns, notEmpty](auto const& t){ + std::ranges::for_each(tables, [&fields, &columns, notEmpty](auto const& t) { std::ranges::copy(t->fields(), std::back_inserter(fields)); if (notEmpty) { std::ranges::copy(t->columns(), std::back_inserter(columns)); @@ -84,7 +84,8 @@ std::shared_ptr ArrowHelpers::joinTables(std::vector requires(std::same_as) auto makeString(T const& str) @@ -108,7 +109,7 @@ void canNotJoin(std::vector> const& tables, std::s } } } -} +} // namespace std::shared_ptr ArrowHelpers::joinTables(std::vector>&& tables, std::span labels) { diff --git a/Framework/Core/src/AnalysisHelpers.cxx b/Framework/Core/src/AnalysisHelpers.cxx index 326be388b2569..b7eac692d3859 100644 --- a/Framework/Core/src/AnalysisHelpers.cxx +++ b/Framework/Core/src/AnalysisHelpers.cxx @@ -65,13 +65,13 @@ std::shared_ptr IndexBuilder::materialize(std::vector> arrays; arrays.reserve(builders.size()); - std::ranges::transform(builders, std::back_inserter(arrays), [](auto& builder){ return builder.result(); }); + std::ranges::transform(builders, std::back_inserter(arrays), [](auto& builder) { return builder.result(); }); return arrow::Table::Make(schema, arrays); } @@ -130,7 +130,7 @@ std::shared_ptr spawnerHelper(std::shared_ptr const& } arrays.reserve(nColumns); - std::ranges::transform(chunks, std::back_inserter(arrays), [](auto&& chunk){ return std::make_shared(chunk); }); + std::ranges::transform(chunks, std::back_inserter(arrays), [](auto&& chunk) { return std::make_shared(chunk); }); return arrow::Table::Make(newSchema, arrays); } @@ -175,7 +175,7 @@ std::vector> extractSources(ProcessingContext& pc, { std::vector> tables; tables.reserve(matchers.size()); - std::ranges::transform(matchers, std::back_inserter(tables), [&pc](auto const& matcher){ return pc.inputs().get(matcher)->asArrowTable(); }); + std::ranges::transform(matchers, std::back_inserter(tables), [&pc](auto const& matcher) { return pc.inputs().get(matcher)->asArrowTable(); }); return tables; } diff --git a/Framework/Core/src/ArrowSupport.cxx b/Framework/Core/src/ArrowSupport.cxx index ef0f84812e3a4..60277dfc38a74 100644 --- a/Framework/Core/src/ArrowSupport.cxx +++ b/Framework/Core/src/ArrowSupport.cxx @@ -531,7 +531,7 @@ o2::framework::ServiceSpec ArrowSupport::arrowBackendSpec() dh->dataOrigin.str, dh->dataDescription.str); continue; } - bool forwarded = std::ranges::any_of(ctx.services().get().forwards, [&dh](auto const& forward){ return DataSpecUtils::match(forward.matcher, *dh); }); + bool forwarded = std::ranges::any_of(ctx.services().get().forwards, [&dh](auto const& forward) { return DataSpecUtils::match(forward.matcher, *dh); }); if (forwarded) { O2_SIGNPOST_EVENT_EMIT(rate_limiting, sid, "offer", "Message %{public}.4s/%{public}.16s is forwarded so we are not returning its memory.", diff --git a/Framework/Core/src/WorkflowHelpers.cxx b/Framework/Core/src/WorkflowHelpers.cxx index 6e62683e1bf4f..ff1ff1f4cf13d 100644 --- a/Framework/Core/src/WorkflowHelpers.cxx +++ b/Framework/Core/src/WorkflowHelpers.cxx @@ -440,21 +440,21 @@ void WorkflowHelpers::injectServiceDevices(WorkflowSpec& workflow, ConfigContext // Check if any of the provided outputs is a DISTSTF // Check if any of the requested inputs is for a 0xccdb message bool providesDISTSTF = std::ranges::any_of(workflow, - [&matcher](auto const& dp) { - return std::any_of(dp.outputs.begin(), dp.outputs.end(), [&matcher](auto const& output) { - return DataSpecUtils::match(matcher, output); - }); - }); + [&matcher](auto const& dp) { + return std::any_of(dp.outputs.begin(), dp.outputs.end(), [&matcher](auto const& output) { + return DataSpecUtils::match(matcher, output); + }); + }); // If there is no CCDB requested, but we still ask for a FLP/DISTSUBTIMEFRAME/0xccdb // we add to the first data processor which has no inputs (apart from // enumerations / timers) the responsibility to provide the DISTSUBTIMEFRAME bool requiresDISTSUBTIMEFRAME = std::ranges::any_of(workflow, - [&dstf](auto const& dp) { - return std::any_of(dp.inputs.begin(), dp.inputs.end(), [&dstf](auto const& input) { - return DataSpecUtils::match(input, dstf); - }); - }); + [&dstf](auto const& dp) { + return std::any_of(dp.inputs.begin(), dp.inputs.end(), [&dstf](auto const& input) { + return DataSpecUtils::match(input, dstf); + }); + }); // We find the first device which has either just enumerations or // just timers, and we will add the DISTSUBTIMEFRAME to it. @@ -694,7 +694,7 @@ void WorkflowHelpers::adjustTopology(WorkflowSpec& workflow, ConfigContext const if (distSTFCount > 0) { for (auto& spec : workflow) { - if (std::ranges::any_of(spec.outputs, [](auto const& output){ return DataSpecUtils::match(output, ConcreteDataMatcher{"FLP", "DISTSUBTIMEFRAME", 0}); })) { + if (std::ranges::any_of(spec.outputs, [](auto const& output) { return DataSpecUtils::match(output, ConcreteDataMatcher{"FLP", "DISTSUBTIMEFRAME", 0}); })) { for (unsigned int i = 1; i < distSTFCount; ++i) { spec.outputs.emplace_back(OutputSpec{ConcreteDataMatcher{"FLP", "DISTSUBTIMEFRAME", i}, Lifetime::Timeframe}); }