Спичек Денис. Технология SEQ-MPI. Скалярное произведение векторов. Вариант 9.

tasks/spichek_d_dot_product_of_vectors/common/include/common.hpp

@@ -0,0 +1,19 @@
+#pragma once
+
+#include <string>
+#include <tuple>
+#include <utility>
+#include <vector>
+
+#include "task/include/task.hpp"
+
+namespace spichek_d_dot_product_of_vectors {
+
+// Пара векторов как входные данные
+using InType = std::pair<std::vector<int>, std::vector<int>>;
+using OutType = int;
+// Тестовые параметры: (пара_векторов, описание)
+using TestType = std::tuple<std::pair<std::vector<int>, std::vector<int>>, std::string>;
+using BaseTask = ppc::task::Task<InType, OutType>;
+
+}  // namespace spichek_d_dot_product_of_vectors

tasks/spichek_d_dot_product_of_vectors/info.json

@@ -0,0 +1,9 @@
+{
+  "student": {
+    "first_name": "Денис",
+    "last_name": "Спичек",
+    "middle_name": "Игоревич",
+    "group_number": "3823Б1ФИ1",
+    "task_number": "1"
+  }
+}

tasks/spichek_d_dot_product_of_vectors/mpi/include/ops_mpi.hpp

@@ -0,0 +1,22 @@
+#pragma once
+
+#include "spichek_d_dot_product_of_vectors/common/include/common.hpp"
+#include "task/include/task.hpp"
+
+namespace spichek_d_dot_product_of_vectors {
+
+class SpichekDDotProductOfVectorsMPI : public BaseTask {
+ public:
+  static constexpr ppc::task::TypeOfTask GetStaticTypeOfTask() {
+    return ppc::task::TypeOfTask::kMPI;
+  }
+  explicit SpichekDDotProductOfVectorsMPI(const InType &in);
+
+ private:
+  bool ValidationImpl() override;
+  bool PreProcessingImpl() override;
+  bool RunImpl() override;
+  bool PostProcessingImpl() override;
+};
+
+}  // namespace spichek_d_dot_product_of_vectors

tasks/spichek_d_dot_product_of_vectors/mpi/src/ops_mpi.cpp

@@ -0,0 +1,86 @@
+#include "spichek_d_dot_product_of_vectors/mpi/include/ops_mpi.hpp"
+
+#include <mpi.h>
+
+#include <algorithm>
+#include <cstddef>
+#include <cstdint>
+#include <vector>
+
+#include "spichek_d_dot_product_of_vectors/common/include/common.hpp"
+
+namespace spichek_d_dot_product_of_vectors {
+
+SpichekDDotProductOfVectorsMPI::SpichekDDotProductOfVectorsMPI(const InType &in) {
+  SetTypeOfTask(GetStaticTypeOfTask());
+  GetInput() = in;
+  GetOutput() = 0;
+}
+
+bool SpichekDDotProductOfVectorsMPI::ValidationImpl() {
+  const auto &[vector1, vector2] = GetInput();
+  return vector1.size() == vector2.size();
+}
+
+bool SpichekDDotProductOfVectorsMPI::PreProcessingImpl() {
+  GetOutput() = 0;
+  return true;
+}
+
+bool SpichekDDotProductOfVectorsMPI::RunImpl() {
+  int rank = 0;
+  int size = 0;
+  MPI_Comm_rank(MPI_COMM_WORLD, &rank);
+  MPI_Comm_size(MPI_COMM_WORLD, &size);
+
+  const auto &[v1, v2] = GetInput();
+  int n = 0;
+  if (rank == 0) {
+    n = static_cast<int>(v1.size());
+  }
+  MPI_Bcast(&n, 1, MPI_INT, 0, MPI_COMM_WORLD);
+
+  if (n == 0 || (rank == 0 && static_cast<size_t>(n) != v2.size())) {
+    GetOutput() = 0;
+    return true;
+  }
+
+  std::vector<int> counts(size);
+  std::vector<int> displs(size);
+
+  int base = n / size;
+  int rem = n % size;
+
+  for (int i = 0; i < size; ++i) {
+    counts[i] = base + (i < rem ? 1 : 0);
+    // [Исправлено] Добавлены скобки для явного приоритета операций
+    displs[i] = (i * base) + std::min(i, rem);
+  }
+
+  int local_count = counts[rank];
+
+  std::vector<int> lv1(local_count);
+  std::vector<int> lv2(local_count);
+
+  MPI_Scatterv(rank == 0 ? v1.data() : nullptr, counts.data(), displs.data(), MPI_INT, lv1.data(), local_count, MPI_INT,
+               0, MPI_COMM_WORLD);
+  MPI_Scatterv(rank == 0 ? v2.data() : nullptr, counts.data(), displs.data(), MPI_INT, lv2.data(), local_count, MPI_INT,
+               0, MPI_COMM_WORLD);
+
+  int64_t local_dot = 0;
+  for (int i = 0; i < local_count; ++i) {
+    local_dot += static_cast<int64_t>(lv1[i]) * lv2[i];
+  }
+
+  int64_t global_dot = 0;
+  MPI_Allreduce(&local_dot, &global_dot, 1, MPI_INT64_T, MPI_SUM, MPI_COMM_WORLD);
+
+  GetOutput() = static_cast<OutType>(global_dot);
+  return true;
+}
+
+bool SpichekDDotProductOfVectorsMPI::PostProcessingImpl() {
+  return true;
+}
+
+}  // namespace spichek_d_dot_product_of_vectors