Hola a todos !!! , les hago una consulta estoy empezando con la programacion en c++ y en mpi ... encontre un codigo que simula el sorteo de loteria en msdn , el problema es que estoy tratando de implementar el codigo pero en c++ puro , porque estoy armando un cluster en linux, con el sistema operativo bccd, hay un par de funciones que no puedo darme cuenta correctamente como hacer para pasarla completamente a c++ sin usar la libreria windows.h y algorithm por ejemplo "result = find( Draw.begin( ), Draw.end( ), num );" este tipo de linea de codigos.. .. a ver si alguien puede ayudarme o aclararme un poco las ideas desde ya muchas gracias por pasarse por el post! y mucho mas por leerlo .. un saludo
P.D : la pagina en la que se encuentra completamente explicado el problema es en "code.msdn.microsoft.com/LotteryMPI"
/* Main.cpp */
#include <windows.h>
#include <mpi.h>
#include <time.h>
#include <list>
#include <algorithm>
#include <iostream>
using namespace::std;
void SaveNumOfDraws(char draw[], unsigned long count, double elapsed_time);
//
// Globals:
//
int myRank;
int numProcs;
char host[256];
int main(int argc, char* argv[])
{
char msg[400];
char terminate[12];
MPI_Status status, stat[10];
int src = MPI_ANY_SOURCE; // receive from any worker
int tag = MPI_ANY_TAG; // tag is being ignored
int Play[6] = {0,0,0,0,0,0};
int flag = 0;
int index;
int bTerminate=0;
clock_t start, finish;
double elapsed_time;
int range_min, range_max;
unsigned long recvbuf;
unsigned long count=0;
using namespace std;
list <int> Draw;
list <int>::iterator Iter;
list <int>::iterator result;
range_min = 1;
range_max = 71;
start = clock();
MPI_Init(&argc, &argv); //initiate the MPI environment
MPI_Comm_size(MPI_COMM_WORLD, &numProcs); // number of processes involved in run
MPI_Comm_rank(MPI_COMM_WORLD, &myRank); // my process id: 0 <= myRank < numProcs
gethostname(host, sizeof(host)/sizeof(host[0])); // machine we are running on
if (myRank > 0)
{ // workers code
int dest = 0; // process 0
int tag = 0; // any value will do
src = 0;
int n = 0;
int num;
bool winner = false;
MPI_Barrier(MPI_COMM_WORLD);
//receive player numbers
MPI_Recv(Play, 6, MPI_INT, 0, 0, MPI_COMM_WORLD, &status);
// Seed the random-number generator with the current time so that
// the numbers will be different every time we run.
srand( myRank * (unsigned) time(NULL) );
do
{
Draw.push_back ((double)rand() / (32767 + 1) * (range_max - range_min) + range_min);
do
{
num = ((double)rand() / (32767 + 1) * (range_max - range_min) + range_min);
result = find( Draw.begin( ), Draw.end( ), num );
if (result == Draw.end()){
Draw.push_back(num);
n++;
}
} while (n<5);
result = find( Draw.begin( ), Draw.end( ), Play[0] );
if ( result != Draw.end( ) ) {
result = find( Draw.begin( ), Draw.end( ), Play[1] );
if ( result != Draw.end( ) ) {
result = find( Draw.begin( ), Draw.end( ), Play[2] );
if ( result != Draw.end( ) ) {
result = find( Draw.begin( ), Draw.end( ), Play[3] );
if ( result != Draw.end( ) ) {
result = find( Draw.begin( ), Draw.end( ), Play[4] );
if ( result != Draw.end( ) ) {
result = find( Draw.begin( ), Draw.end( ), Play[5] );
if ( result != Draw.end( ) ) {
sprintf_s(msg, 400, "Process %d at %s found a Winner after: ", myRank, host);
MPI_Send(msg, (int) strlen(msg)+1, MPI_CHAR, 0, 0, MPI_COMM_WORLD);
}
}
}
}
}
}
Draw.clear ();
count++;
n=0;
MPI_Iprobe( 0, 0, MPI_COMM_WORLD, &flag, &status );
}while (!flag);
MPI_Recv(terminate, 12, MPI_CHAR, 0, 0, MPI_COMM_WORLD, &status);
//cout << terminate << endl;
MPI_Reduce( &count, &recvbuf, 1, MPI_UNSIGNED_LONG, MPI_SUM, 0, MPI_COMM_WORLD);
}
else
{ // master's code
int numargs;
//read command-line arguments
for( numargs = 1; numargs < argc; numargs++ )
Play[numargs-1] = atol(argv[numargs]);
MPI_Request *rreqs = (MPI_Request *)malloc((numProcs-1) * sizeof(MPI_Request));
MPI_Barrier(MPI_COMM_WORLD);
sprintf_s(msg, 256, "Master process %d is running on '%s'.", myRank, host);
cout << msg << endl;
//sends the play numbers to all processes
for (int proc = 1; proc < numProcs; proc++) // for each of the workers:
{
MPI_Send(Play, 6, MPI_INT, proc, 0 /* tag */, MPI_COMM_WORLD);
}
//assync request awaiting for a winner process to comunicate
for (int proc = 1; proc < numProcs; proc++) // for each of the workers:
{
MPI_Irecv(msg, 400, MPI_CHAR, proc, tag, MPI_COMM_WORLD, &rreqs[proc-1]);
}
//wait to receive a notification from the process with a winner draw
MPI_Waitany(numProcs-1, rreqs, &index, stat);
sprintf_s(terminate, 12, "TERMINATED");
//notify all process that a winner was found. They should terminate now
for (int proc = 1; proc < numProcs; proc++) // for each of the workers:
{
MPI_Send(terminate, 12, MPI_CHAR, proc, 0 /* tag */, MPI_COMM_WORLD);
}
MPI_Reduce( &count, &recvbuf, 1, MPI_UNSIGNED_LONG, MPI_SUM, 0, MPI_COMM_WORLD);
finish = clock();
elapsed_time = difftime(finish, start);
SaveNumOfDraws(msg, recvbuf, elapsed_time);
bTerminate = 1;
}
MPI_Finalize();
return 0;
}
void SaveNumOfDraws(char draw[], unsigned long count, double elapsed_time)
{
char c = 'n';
FILE *stream;
errno_t err;
// Open for append
err = fopen_s( &stream, "numberofDraws.txt", "a+" );
if( err == 0 )
{
//printf( "The file 'numberofDraws.txt' was openedn" );
}
else
{
//printf( "The file 'numberofDraws.txt' was not openedn" );
}
fprintf_s( stream, "%s%u %6.5f%c", draw, count, elapsed_time, c );
fclose( stream );
}
