Commit 229ac3cf authored by Guillaume Baulieu's avatar Guillaume Baulieu
Browse files

Example of an emulator actor using redis for block transfers

parent 0b07f893
......@@ -45,18 +45,26 @@
// AGAPRO
#include "BasicAFP.h"
#include "RedisAFC.h"
#include "NNPSAFilter.h"
#include "BasicAFC.h"
#include "PSAFilterGridSearch.h"
// local
#include "DPEmulator.h"
#include "SCEmulator.h"
// ADF
//#include "BlackHole.h"
int TestPSA()
{
EmulatorPFC<BasicAFP, NNPSAFilter, RedisAFC> *emulator =
new EmulatorPFC<BasicAFP, NNPSAFilter, RedisAFC>("./",1024*1024*100);
//DPProducer<BasicAFP> *emulator = new DPProducer<BasicAFP>("./","134.158.140.20",7000,1024*1024*10);
//emulator->addOutputActor("PSAFilterGridSearch");
//emulator->addOutputActor("BasicAFC");
//DPFilter<PSAFilterGridSearch> *emulator = new DPFilter<PSAFilterGridSearch>("./","134.158.140.20",7000,1024*1024*100);
//emulator->addOutputActor("BasicAFC");
DPConsumer<BasicAFC> *emulator = new DPConsumer<BasicAFC>("./","134.158.140.20",7000);
//EmulatorPFC<BasicAFP, PSAFilterGridSearch, BasicAFC> *emulator = new EmulatorPFC<BasicAFP, PSAFilterGridSearch, BasicAFC>("./",1024*1024*10);
if ( ! emulator->Init() )
{
return 1;
......@@ -72,84 +80,9 @@ int TestPSA()
return 0;
}
/*
int TestClass_AllHisto()
{
EmulatorPFC<GANPRO::BasicMFMP,GANPRO::TSorter,GANPRO::AllHisto> *emulator = new EmulatorPFC<GANPRO::BasicMFMP,GANPRO::TSorter,GANPRO::AllHisto>("./");
//emulator->fMaxTry = 15;
if ( ! emulator->Init() )
{
return 1;
}
// run
emulator->Run();
delete emulator;
return 0;
}
*/
/*
int TestClass_NedaHisto()
{
EmulatorPC<GANPRO::BasicMFMP,GANPRO::NedaHisto> *emulator = new EmulatorPC<GANPRO::BasicMFMP,GANPRO::NedaHisto>("./");
if ( ! emulator->Init() )
{
return 1;
}
// run
emulator->Run();
delete emulator;
return 0;
}
int TestClass_ExogamHisto()
{
EmulatorPC<GANPRO::BasicMFMP,GANPRO::ExogamHisto> *emulator = new EmulatorPC<GANPRO::BasicMFMP,GANPRO::ExogamHisto>("./");
if ( ! emulator->Init() )
{
return 1;
}
// run
emulator->Run();
delete emulator;
return 0;
}
int TestClass_TSorter()
{
EmulatorPFC<GANPRO::MultiBasicMFMP,GANPRO::TSorter,GANPRO::BasicMFMC> *emulator =
new EmulatorPFC<GANPRO::MultiBasicMFMP,GANPRO::TSorter,GANPRO::BasicMFMC>("./");
// Initialize
if ( !emulator->Init() )
{
return 1;
}
// Main Loop
emulator->Run();
delete emulator;
return 0;
}
*/
int main (int argc, char *argv[])
{
return TestPSA();
//return TestClass_NedaHisto();
//return TestClass_ExogamHisto();
}
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment