lab2.2

// Необходимо реализовать эту программу через функции Send и Recv

#include <mpi.h>
#include <stdio.h>
#include <iostream>

using namespace std;

int main(int argc, char** argv)
{
    int myid, n = 3, *A = 0, *B = 0, buf = 0;
    int size;
    MPI_Status status;
    MPI_Comm comm = MPI_COMM_WORLD;
    MPI_Init(&argc, &argv);
    MPI_Comm_size(comm, &size);
    MPI_Comm_rank(comm, &myid);

    B = new int [size * n];
    A = new int [size * n];

    for(int i = 0; i < size * n; i++)
    {
        B[i] = myid;
    }


    for(int i = 0; i < size ; i++)// Отправлю з-е другим потокам и присваиваю з-е своиму потоку своего
        {
          if(myid != i){
            buf = B[i];
            MPI_Send(&buf, 1, MPI_INT, i, 0, MPI_COMM_WORLD);
          }else
          {
            int k = myid * n;
            for (int j = 0 ; j < n ; j++)
            {
                A[k + j] = B[i];
            }
        }
    }

    cout << "Process " << myid << " | ";

    for(int i = 0; i < size * n; i++)
        cout << "  " << B[i];

    int c = 0, BUF = 0;

    for(int j = 0; j < size ; j++)
    {
        if(myid != j){// Поток не должен слушать себя
            MPI_Recv(&BUF,1,MPI_INT,j,0,MPI_COMM_WORLD,&status);            // можно было не писать цикл ниже , а сразу определить нужное мето для вставки значения и вставить его именно туда
            for(int i = 0 ; i < size * n ; i+=n)// Не работает для нулевого потока
            {
                if(c == j)
                {
                    for(int k = 0 ; k < n ; k++)
                    {
                        A[i + k] = BUF;
                    }

                }
                // if(c > myid)
                // {
                //     break;
                // }
                c++;
            }
            c = 0;
            BUF = 0;
        }
    }

    cout << "       " << "Process " << myid << " | ";
    for(int i = 0; i < size * n; i++)
        cout << "  " << A[i];
    cout << endl;

    MPI_Finalize();
}