From d54e88dd165feaef3858585b03740f4ba0249c73 Mon Sep 17 00:00:00 2001 From: Benjamin Bouvier Date: Fri, 13 Jul 2012 15:07:42 +0200 Subject: [PATCH] eoMultiParallelApply is no more used, replaced with eo::mpi::MultiJob instead. --- eo/src/mpi/eoMultiParallelApply.h | 57 ------------------------------- 1 file changed, 57 deletions(-) delete mode 100644 eo/src/mpi/eoMultiParallelApply.h diff --git a/eo/src/mpi/eoMultiParallelApply.h b/eo/src/mpi/eoMultiParallelApply.h deleted file mode 100644 index f4fe47b5..00000000 --- a/eo/src/mpi/eoMultiParallelApply.h +++ /dev/null @@ -1,57 +0,0 @@ -# ifndef __EO_MULTI_PARALLEL_APPLY_H__ -# define __EO_MULTI_PARALLEL_APPLY_H__ - -# include "eoParallelApply.h" - -namespace eo -{ - namespace mpi - { - template< class EOT > - class ProcessTaskParallelEval : public ProcessTaskParallelApply - { - public: - - using ProcessTaskParallelApply::_wrapped; - using ProcessTaskParallelApply::d; - - void operator()() - { - int order = Message::Continue; - while( order != Message::Finish ) - { - _wrapped->operator()(); - d->comm.recv( d->masterRank, Channel::Commands, order ); - } - } - - ~ProcessTaskParallelEval() - { - } - }; - - template< class EOT > - struct ParallelEvalStore : public ParallelApplyStore< EOT > - { - using ParallelApplyStore::wrapProcessTask; - - ParallelEvalStore( - eoUF & _proc, - int _masterRank, - int _packetSize = 1 - ) : - ParallelApplyStore< EOT >( _proc, *( new std::vector ), _masterRank, _packetSize ) - // FIXME memory leak because of vector ==> use const correctness - { - wrapProcessTask( new ProcessTaskParallelEval ); - } - - void data( std::vector& _pop ) - { - ParallelApplyStore::_data.init( _pop ); - } - }; - } -} -# endif // __EO_PARALLEL_APPLY_H__ -