eo::mpi experiment functional again with paradiseo.
This commit is contained in:
parent
a90fdcbe18
commit
86436fb9e4
3 changed files with 8 additions and 4 deletions
|
|
@ -3,6 +3,10 @@ README
|
|||
|
||||
To launch a set of experiments with t-mpi-distrib-exp:
|
||||
|
||||
0) Compile it:
|
||||
|
||||
mpic++ -o distrib-exp t-mpi-distrib-exp.cpp -I../../src/ -I../../src/mpi/ -DWITH_MPI -L ../../../build/eo/lib/ -leoutils -leo -leompi -leoserial
|
||||
|
||||
1) Generate the experiments, thanks to the script gen-xp.py
|
||||
This script will guide you and ask you for all experiments. The prefix is used in the results filenames.
|
||||
You may want to modify the name of the experiments file (default value: "experiments.json") or
|
||||
|
|
|
|||
|
|
@ -1,6 +1,6 @@
|
|||
{
|
||||
"experiments":[
|
||||
{"size":"10", "packet_size":"1", "seed":"1337", "distribution":{"name":"normal", "mean":"500", "stddev":"100"}, "worker_print_waiting_time":"1", "filename":""}
|
||||
{"size":"10", "packet_size":"1", "seed":"1337", "distribution":{"name":"normal", "mean":"500", "stddev":"100"}, "worker_print_waiting_time":"1", "filename":"exp1.result.txt"},
|
||||
{"size":"10", "packet_size":"1", "seed":"1337", "distribution":{"name":"normal", "mean":"100", "stddev":"20"}, "worker_print_waiting_time":"1", "filename":"exp2.result.txt"}
|
||||
]
|
||||
}
|
||||
|
|
|
|||
|
|
@ -39,7 +39,7 @@
|
|||
|
||||
# include <eo>
|
||||
|
||||
# include <mpi/eoParallelApply.h>
|
||||
# include <mpi/eoMpi.h>
|
||||
# include "t-mpi-common.h"
|
||||
|
||||
using namespace eo::mpi;
|
||||
|
|
@ -389,7 +389,7 @@ class Experiment : public eoserial::Persistent
|
|||
_distribution->clear();
|
||||
_distribution->fill( _size );
|
||||
|
||||
timerStat.start("run");
|
||||
eo::mpi::timerStat.start("run");
|
||||
Wait wait( _worker_print_waiting_time );
|
||||
ParallelApplyStore< type > store( wait, DEFAULT_MASTER, _packet_size );
|
||||
store.data( *_distribution );
|
||||
|
|
@ -397,7 +397,7 @@ class Experiment : public eoserial::Persistent
|
|||
ParallelApply< type > job( scheduling, DEFAULT_MASTER, store );
|
||||
|
||||
job.run();
|
||||
timerStat.stop("run");
|
||||
eo::mpi::timerStat.stop("run");
|
||||
if( job.isMaster() )
|
||||
{
|
||||
EmptyJob( scheduling, DEFAULT_MASTER ); // to terminate parallel apply
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue