nojhan/eodev
Archived
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Updated tests: multipleRoles compiles again and parallelApply tries all kinds of assignments algorithms.

Browse source
This commit is contained in:
Benjamin Bouvier 2012-06-22 16:14:27 +02:00
commit aec5236eb1
2 changed files with 45 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

10
eo/test/mpi/multipleRoles.cpp
View file

@ -27,8 +27,7 @@ void subtask( vector<int>& v )
DynamicAssignmentAlgorithm algo( 2, MpiNode::comm().size()-1 );
plusOne plusOneInstance;
ParallelApply<int> job( plusOneInstance, v, algo, 1 );
Role node( job );
node.run();
job.run();
}
struct transmit : public eoUF< vector<int>&, void >
@ -37,7 +36,7 @@ struct transmit : public eoUF< vector<int>&, void >
{
cout << "Into the master subjob..." << endl;
subtask( v );
}
}
};
int main(int argc, char** argv)
@ -64,9 +63,8 @@ int main(int argc, char** argv)
// only one node is assigned to subjob mastering
DynamicAssignmentAlgorithm algo( 1, 1 );
ParallelApply< vector<int> > job( transmitInstance, metaV, algo, 0 );
Role node( job );
node.run();
if( node.master() )
job.run();
if( job.isMaster() )
{
v = metaV[0];
cout << "Results : " << endl;

58
eo/test/mpi/parallelApply.cpp
View file

@ -14,16 +14,18 @@ struct plusOne : public eoUF< int&, void >
}
};
struct Test
{
AssignmentAlgorithm * assign;
string description;
};
int main(int argc, char** argv)
{
eo::log << eo::setlevel( eo::debug );
cout << "Appel à init... " << endl;
// eo::log << eo::setlevel( eo::debug );
MpiNode::init( argc, argv );
DynamicAssignmentAlgorithm assign( 1, MpiNode::comm().size()-1 );
cout << "Création des données... " << endl;
vector<int> v;
v.push_back(1);
v.push_back(3);
v.push_back(3);
@ -32,18 +34,44 @@ int main(int argc, char** argv)
plusOne plusOneInstance;
cout << "Création du job..." << endl;
ParallelApply<int> job( plusOneInstance, v, assign, 0 );
job.run();
vector< Test > tests;
if( job.isMaster() )
Test tStatic;
tStatic.assign = new StaticAssignmentAlgorithm( 1, MpiNode::comm().size()-1, v.size() );
tStatic.description = "Correct static assignment.";
tests.push_back( tStatic );
Test tStaticOverload;
tStaticOverload.assign = new StaticAssignmentAlgorithm( 1, MpiNode::comm().size()-1, v.size()+100 );
tStaticOverload.description = "Static assignment with too many runs.";
tests.push_back( tStaticOverload );
Test tDynamic;
tDynamic.assign = new DynamicAssignmentAlgorithm( 1, MpiNode::comm().size()-1 );
tDynamic.description = "Dynamic assignment.";
tests.push_back( tDynamic );
for( unsigned int i = 0; i < tests.size(); ++i )
{
for(int i = 0; i < v.size(); ++i)
{
cout << v[i] << ' ';
}
cout << endl;
}
ParallelApply<int> job( plusOneInstance, v, *(tests[i].assign), 0 );
if( job.isMaster() )
{
cout << "Test : " << tests[i].description << endl;
}
job.run();
if( job.isMaster() )
{
for(int i = 0; i < v.size(); ++i)
{
cout << v[i] << ' ';
}
cout << endl;
}
delete tests[i].assign;
}
return 0;
}