feat: add vector average task (MPI+SEQ) - variant 4

Author: bizi2

tasks/nazyrov_a_a_vector_avg/common/include/common.hpp

@@ -0,0 +1,16 @@
+#pragma once
+
+#include <string>
+#include <tuple>
+#include <vector>
+
+#include "task/include/task.hpp"
+
+namespace nazyrov_a_a_vector_avg {
+
+using InType = std::vector<int>;
+using OutType = double;
+using TestType = std::tuple<int, std::string>;
+using BaseTask = ppc::task::Task<InType, OutType>;
+
+}  // namespace nazyrov_a_a_vector_avg

tasks/nazyrov_a_a_vector_avg/data/pic.ppm

@@ -0,0 +1,7 @@
+{
+  "student": {
+    "full_name": "full_name_p",
+    "group_number": "2222222_p",
+    "task_number": "1"
+  }
+}

tasks/nazyrov_a_a_vector_avg/info.json

@@ -0,0 +1,27 @@
+#pragma once
+
+#include "../../../nazyrov_a_a_vector_avg/common/include/common.hpp"
+
+namespace nazyrov_a_a_vector_avg {
+
+class VectorAvgMPI : public BaseTask {
+ public:
+  explicit VectorAvgMPI(const InType &in);
+  ~VectorAvgMPI() override = default;
+
+  static constexpr ppc::task::TypeOfTask GetStaticTypeOfTask() {
+    return ppc::task::TypeOfTask::kMPI;
+  }
+
+ protected:
+  bool ValidationImpl() override;
+  bool PreProcessingImpl() override;
+  bool RunImpl() override;
+  bool PostProcessingImpl() override;
+
+ private:
+  int world_rank_{0};
+  int world_size_{1};
+};
+
+}  // namespace nazyrov_a_a_vector_avg

tasks/nazyrov_a_a_vector_avg/mpi/include/ops_mpi.hpp

@@ -0,0 +1,50 @@
+#include "../../../nazyrov_a_a_vector_avg/mpi/include/ops_mpi.hpp"
+
+#include <mpi.h>
+
+#include <numeric>
+
+namespace nazyrov_a_a_vector_avg {
+
+VectorAvgMPI::VectorAvgMPI(const InType &in) : BaseTask() {
+  GetInput() = in;
+  MPI_Comm_rank(MPI_COMM_WORLD, &world_rank_);
+  MPI_Comm_size(MPI_COMM_WORLD, &world_size_);
+}
+
+bool VectorAvgMPI::ValidationImpl() {
+  return true;
+}
+
+bool VectorAvgMPI::PreProcessingImpl() {
+  return true;
+}
+
+bool VectorAvgMPI::RunImpl() {
+  const auto &input = GetInput();
+  int n = static_cast<int>(input.size());
+  int local_n = n / world_size_;
+  int start = world_rank_ * local_n;
+  int end = (world_rank_ == world_size_ - 1) ? n : start + local_n;
+
+  double local_sum = std::accumulate(input.begin() + start, input.begin() + end, 0.0);
+  int local_count = end - start;
+
+  double global_sum = 0.0;
+  int global_count = 0;
+
+  MPI_Reduce(&local_sum, &global_sum, 1, MPI_DOUBLE, MPI_SUM, 0, MPI_COMM_WORLD);
+  MPI_Reduce(&local_count, &global_count, 1, MPI_INT, MPI_SUM, 0, MPI_COMM_WORLD);
+
+  if (world_rank_ == 0) {
+    GetOutput() = global_sum / static_cast<double>(global_count);
+  }
+
+  return true;
+}
+
+bool VectorAvgMPI::PostProcessingImpl() {
+  return true;
+}
+
+}  // namespace nazyrov_a_a_vector_avg

tasks/nazyrov_a_a_vector_avg/mpi/src/ops_mpi.cpp

@@ -0,0 +1,23 @@
+#pragma once
+
+#include "../../../nazyrov_a_a_vector_avg/common/include/common.hpp"
+
+namespace nazyrov_a_a_vector_avg {
+
+class VectorAvgSEQ : public BaseTask {
+ public:
+  explicit VectorAvgSEQ(const InType &in);
+  ~VectorAvgSEQ() override = default;
+
+  static constexpr ppc::task::TypeOfTask GetStaticTypeOfTask() {
+    return ppc::task::TypeOfTask::kSEQ;
+  }
+
+ protected:
+  bool ValidationImpl() override;
+  bool PreProcessingImpl() override;
+  bool RunImpl() override;
+  bool PostProcessingImpl() override;
+};
+
+}  // namespace nazyrov_a_a_vector_avg

tasks/nazyrov_a_a_vector_avg/report.md

@@ -0,0 +1,30 @@
+#include "../../../nazyrov_a_a_vector_avg/seq/include/ops_seq.hpp"
+
+#include <numeric>
+
+namespace nazyrov_a_a_vector_avg {
+
+VectorAvgSEQ::VectorAvgSEQ(const InType &in) : BaseTask() {
+  GetInput() = in;
+}
+
+bool VectorAvgSEQ::ValidationImpl() {
+  return true;
+}
+
+bool VectorAvgSEQ::PreProcessingImpl() {
+  return true;
+}
+
+bool VectorAvgSEQ::RunImpl() {
+  const auto &input = GetInput();
+  double sum = std::accumulate(input.begin(), input.end(), 0.0);
+  GetOutput() = sum / static_cast<double>(input.size());
+  return true;
+}
+
+bool VectorAvgSEQ::PostProcessingImpl() {
+  return true;
+}
+
+}  // namespace nazyrov_a_a_vector_avg

tasks/nazyrov_a_a_vector_avg/seq/include/ops_seq.hpp

@@ -0,0 +1,7 @@
+{
+  "tasks": {
+    "mpi": "enabled",
+    "seq": "enabled"
+  },
+  "tasks_type": "processes"
+}

tasks/nazyrov_a_a_vector_avg/seq/src/ops_seq.cpp

@@ -0,0 +1,14 @@
+InheritParentConfig: true
+
+Checks: >
+  -modernize-loop-convert,
+  -cppcoreguidelines-avoid-goto,
+  -cppcoreguidelines-avoid-non-const-global-variables,
+  -misc-override-with-different-visibility,
+  -misc-use-anonymous-namespace,
+  -modernize-use-std-print,
+  -modernize-type-traits
+
+CheckOptions:
+  - key: readability-function-cognitive-complexity.Threshold
+    value: 50  # Relaxed for tests