Зиновьев Александр Задача 1 Вариант 12 Сумма значений по столбцам матрицы #282
Conversation
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## master #282 +/- ##
==========================================
- Coverage 97.12% 96.34% -0.78%
==========================================
Files 87 445 +358
Lines 2263 11421 +9158
Branches 786 4808 +4022
==========================================
+ Hits 2198 11004 +8806
- Misses 29 136 +107
- Partials 36 281 +245 ☔ View full report in Codecov by Sentry. |
|
|
||
| #include <thread> | ||
|
|
||
| using namespace std::chrono_literals; |
| #include <thread> | ||
| #include <vector> | ||
|
|
||
| using namespace std::chrono_literals; |
|
|
||
| using namespace std::chrono_literals; | ||
|
|
||
| std::vector<int> zinoviev_a_sum_cols_matrix_mpi::generateRandomVector(int sz) { |
There was a problem hiding this comment.
Your tests are failed because there function generateRandomVector has parametr - int sz, but in include function generateRandomVector has parametr - int size. Thats why tests give an error zinoviev_a_sum_cols_matrix_mpi::generateRandomVector has a definition with different parameter names. Change parametr name - give the parematr only one name.
| } | ||
| return sums; | ||
| } | ||
|
|
There was a problem hiding this comment.
In functions computeLinearCoordinates and calculateMatrixSumSequential the same problem. Change parametr name - give the parematr only one name.
| std::vector<int> zinoviev_a_sum_cols_matrix_mpi::generateRandomVector(int size) { | ||
| std::random_device dev; | ||
| std::mt19937 gen(dev()); | ||
| std::vector<int> vec(size); | ||
| for (int i = 0; i < size; i++) { | ||
| vec[i] = gen() % 100; | ||
| } | ||
| return vec; | ||
| } | ||
|
|
There was a problem hiding this comment.
Please, move test functions to the test module
| broadcast(mpiWorld, numCols, 0); | ||
| broadcast(mpiWorld, numRows, 0); | ||
|
|
||
| if (mpiWorld.rank() == 0) { | ||
| // Initialize the input vector | ||
| inputData_ = std::vector<int>(taskData->inputs_count[0]); | ||
| auto* temp_ptr = reinterpret_cast<int*>(taskData->inputs[0]); | ||
| for (unsigned int i = 0; i < taskData->inputs_count[0]; i++) { | ||
| inputData_[i] = temp_ptr[i]; | ||
| } | ||
| } else { | ||
| inputData_ = std::vector<int>(numCols * numRows); | ||
| } |
There was a problem hiding this comment.
Please, move MPI data transfer to ::run()
| ::testing::InitGoogleTest(&argc, argv); | ||
| return RUN_ALL_TESTS(); | ||
| } | ||
| } |
There was a problem hiding this comment.
Please, do not modify common files!
| std::mt19937 gen(dev()); | ||
| std::vector<int> vec(size); | ||
| for (int i = 0; i < size; i++) { | ||
| vec[i] = gen() % 100; |
Здесь представлены последовательная и параллельная реализации суммы значений по столбцам матрицы. В последовательной реализуем вложенный цикл, проходя по каждому столбцу матрицы, суммируя значения её элементов. Итоговые суммы помещаются в отдельный вектор. В параллельной распределяем столбцы матрицы в зависимости от числа доступных процессов. Определяем величину, которая обозначает количество столбцов, отведенных каждому процессу, а также индекс последнего обрабатываемого столбца для каждого процесса. Каждая группа столбцов суммируется с использованием функции, аналогичной той, что применяется в последовательной версии. Полученные результаты затем консолидируются в общий вектор.