be_mpi_receiver.h

Go to the documentation of this file.

 
#ifndef _BE_MPI_RECEIVER_H
#define _BE_MPI_RECEIVER_H
 
#include <string>
#include <vector>
#include <memory>
 
#include <be_error_exception.h>
#include <be_mpi.h>
#include <be_mpi_resources.h>
#include <be_mpi_workpackage.h>
#include <be_mpi_workpackageprocessor.h>
#include <be_process_forkmanager.h>
 
namespace BiometricEvaluation {
        namespace MPI {
                class Receiver {
                public:
                        Receiver(
                            const std::string &propertiesFileName,
                            const std::shared_ptr<
                                BiometricEvaluation::MPI::WorkPackageProcessor>
                                &workPackageProcessor);
 
                        ~Receiver();
                        
                        void start();
 
                protected:
 
                private:
                        MPI::TaskStatus requestWorkPackages();
                        void sendWorkPackage(MPI::WorkPackage &workPackage);
                        void startWorkers();
                        void shutdown(
                            const MPI::TaskStatus &status,
                            const std::string &reason);
 
                        Process::ForkManager _processManager;
                        
                        std::shared_ptr<MPI::WorkPackageProcessor>
                            _workPackageProcessor;
 
                        std::shared_ptr<MPI::Resources> _resources;
                        std::shared_ptr<IO::Logsheet> _logsheet;
 
                        /*
                         * Declare the class that implements process worker.
                         */
                        class PackageWorker : public Process::Worker
                        {
                        public:
                            PackageWorker(
                                const std::shared_ptr<MPI::WorkPackageProcessor>
                                    &workPackageProcessor,
                                const std::shared_ptr<MPI::Resources>
                                    &resources);
                                        
                            int32_t workerMain();
 
                            ~PackageWorker();
                                
                        private:
                            std::shared_ptr<
                                BiometricEvaluation::MPI::WorkPackageProcessor>
                                    _workPackageProcessor;
                                std::shared_ptr<MPI::Resources> _resources;
                                std::shared_ptr<IO::Logsheet> _logsheet;
                        };
                };
        }
}
 
#endif /* _BE_MPI_RECEIVER_H */