技術標籤：技術測試Testc語言

MPI設定bsendBuffer

#include <stdio.h>
#include <mpi.h>
#include <unistd.h>
#include <stdlib.h>
#include <math.h>

#define buf_size 65539

int main(int argc, char **argv)
{
	int rank, size, other;

	int sb[buf_size];
	int rb[buf_size];
	MPI_Status status;
 

	int bufsize;
	char *buf;

	MPI_Init(&argc,&argv);
	MPI_Comm_size(MPI_COMM_WORLD, &size);
	MPI_Comm_rank(MPI_COMM_WORLD, &rank);

	MPI_Pack_size(buf_size,MPI_INT, MPI_COMM_WORLD,&bufsize);
	bufsize = bufsize + MPI_BSEND_OVERHEAD;
	buf = (char *)malloc(bufsize);
	MPI_Buffer_attach
 
(buf,bufsize);

	for (int i = 0; i < buf_size; i++)
	{
		sb[i] = buf_size * rank + i;
	}

	if (rank == 0)other = 1;
	if (rank == 1)other = 0;

	fprintf(stderr,"process:%d of %d trying sending...\n",rank,size);
	MPI_Bsend(sb,buf_size,MPI_INT,other,1, MPI_COMM_WORLD);
	fprintf(stderr, "process:%d of %d trying receinging...\n"
 
, rank, size);
	MPI_Recv(rb, buf_size, MPI_INT, other, 1, MPI_COMM_WORLD,&status);

	fprintf(stderr, "Hello World!process:%d of %d\n", rank, size);

	MPI_Buffer_detach(&buf,&bufsize);
	free(buf);
	
	MPI_Finalize();

	return 0;
}