Blame test/mpi/cxx/pt2pt/sendrecvx.cxx
|
Packit |
0848f5 |
/* -*- Mode: C++; c-basic-offset:4 ; -*- */
|
|
Packit |
0848f5 |
/*
|
|
Packit |
0848f5 |
* (C) 2001 by Argonne National Laboratory.
|
|
Packit |
0848f5 |
* See COPYRIGHT in top-level directory.
|
|
Packit |
0848f5 |
*
|
|
Packit |
0848f5 |
*/
|
|
Packit |
0848f5 |
/* style: c++ header */
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
/*
|
|
Packit |
0848f5 |
* Simple test program for C++ binding
|
|
Packit |
0848f5 |
*/
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
/* #include <stdio.h> */
|
|
Packit |
0848f5 |
#include "mpi.h"
|
|
Packit |
0848f5 |
#include "mpitestconf.h"
|
|
Packit |
0848f5 |
#include "mpitestcxx.h"
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
#ifdef HAVE_IOSTREAM
|
|
Packit |
0848f5 |
// Not all C++ compilers have iostream instead of iostream.h
|
|
Packit |
0848f5 |
#include <iostream>
|
|
Packit |
0848f5 |
#ifdef HAVE_NAMESPACE_STD
|
|
Packit |
0848f5 |
// Those that do often need the std namespace; otherwise, a bare "cout"
|
|
Packit |
0848f5 |
// is likely to fail to compile
|
|
Packit |
0848f5 |
using namespace std;
|
|
Packit |
0848f5 |
#endif
|
|
Packit |
0848f5 |
#else
|
|
Packit |
0848f5 |
#include <iostream.h>
|
|
Packit |
0848f5 |
#endif
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
int main( int argc, char *argv[] )
|
|
Packit |
0848f5 |
{
|
|
Packit |
0848f5 |
int rank, size, errs = 0;
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MTest_Init();
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
rank = MPI::COMM_WORLD.Get_rank();
|
|
Packit |
0848f5 |
size = MPI::COMM_WORLD.Get_size();
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
if (size < 2) {
|
|
Packit |
0848f5 |
cerr << "Size of comm_world must be at least 2\n";
|
|
Packit |
0848f5 |
MPI::COMM_WORLD.Abort(1);
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
if (rank == 0) {
|
|
Packit |
0848f5 |
int *buf = new int[100];
|
|
Packit |
0848f5 |
int i;
|
|
Packit |
0848f5 |
for (i=0; i<100; i++) buf[i] = i;
|
|
Packit |
0848f5 |
MPI::COMM_WORLD.Send( buf, 100, MPI::INT, size-1, 0 );
|
|
Packit |
0848f5 |
delete[] buf;
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
else if (rank == size - 1) {
|
|
Packit |
0848f5 |
int *buf = new int[100];
|
|
Packit |
0848f5 |
int i;
|
|
Packit |
0848f5 |
MPI::COMM_WORLD.Recv( buf, 100, MPI::INT, 0, 0 );
|
|
Packit |
0848f5 |
for (i=0; i<100; i++) {
|
|
Packit |
0848f5 |
if (buf[i] != i) {
|
|
Packit |
0848f5 |
errs++;
|
|
Packit |
0848f5 |
cerr << "Error: buf[" << i << "] = " << buf[i] << "\n";
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
delete[] buf;
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MTest_Finalize( errs );
|
|
Packit |
0848f5 |
MPI::Finalize();
|
|
Packit |
0848f5 |
return 0;
|
|
Packit |
0848f5 |
}
|