using System;

using Alchemi.Parallel;

using Environment = Alchemi.Parallel.Environment;

namespace ConsoleApplication1

{

class Program

{

static void Main(string[] args)

{

int size, rank, i, j;

object data;

MPI mpi = Alchemi.Parallel.Environment.GetInstance().GetMPI;

mpi.Init();

mpi.Comm_Size(out size);

mpi.Comm_Rank(out rank);

MPI_Comm comm = new MPI_Comm("Andrew");

MPI_Status status = new MPI_Status();

int[] data1,data3;

data1 = new int[5];

data3 = new int[5];

data1[1] = 13; data1[2] = 16; data1[3] = 14;

if (rank == 0)

{

int numWorkers = size-1;

Console.WriteLine("dikasih kesiapa ???jumlah prosesor {0}", numWorkers);

/* kriim ke pekerja */

for (int d = 1; d <= numWorkers; d++)

{

mpi.Send(data1, 1, 0, comm);//format (Data, nomor prosesortujuan,tag nilainya 0, comm

}

/* terima dari pekerja*/

Object offsetArray;

int dest;

for ( int yi = 1; yi <= numWorkers; yi++)

{

//   dest = status.Src;

mpi.Recv(out offsetArray, yi, 0, comm, status);

data3= (int[])offsetArray;

for (i = 1; i < 4; i++)

{

Console.WriteLine("untuk master,data diterima dari pekerja {0}", data3[i]);

}

}

}

else

{

Object payload;

int[] nilai;

int[] nilai2;

nilai2 = new int[5]; nilai = new int[5];

nilai2[1] = 3;

nilai2[2] = 10; nilai2[3] = 4;

/* receive data from master */

//terima dari master

mpi.Recv(out payload, 0, 0, comm, status);

nilai= (int[])payload;

for (int k = 1; k < 4; k++)

{

Console.WriteLine("untuk pekerja,data diterima dari pid 0 nilai  data {0}", nilai[k]);

}

// kirim ke master

mpi.Send(nilai2, 0, 0, comm);

}

mpi.Finalise();

}

}

}